lib/dist updates for structural split changes

Author: mohitpubnub

dist/web/pubnub.js

@@ -42,10 +42,9 @@ var __importDefault = (this && this.__importDefault) || function (mod) {
 };
 Object.defineProperty(exports, "__esModule", { value: true });
 exports.EventEngine = void 0;
-const receiving_1 = require("./states/receiving");
+const states_1 = require("./states");
 const dispatcher_1 = require("./dispatcher");
 const utils_1 = require("../core/utils");
-const unsubscribed_1 = require("./states/unsubscribed");
 const core_1 = require("./core");
 const categories_1 = __importDefault(require("../core/constants/categories"));
 const utils = __importStar(require("../core/utils"));
@@ -71,7 +70,7 @@ class EventEngine {
                 this.dispatcher.dispatch(change.invocation);
             }
         });
-        this.engine.start(unsubscribed_1.UnsubscribedState, undefined);
+        this.engine.start(states_1.UnsubscribedState, undefined);
     }
     /**
      * Subscription-based current timetoken.
@@ -84,7 +83,7 @@ class EventEngine {
             return undefined;
         let referenceTimetoken;
         let currentTimetoken = '0';
-        if (currentState.label === receiving_1.ReceivingState.label) {
+        if (currentState.label === states_1.ReceivingState.label) {
             const context = this.engine.currentContext;
             currentTimetoken = context.cursor.timetoken;
             referenceTimetoken = context.referenceTimetoken;
@@ -118,7 +117,7 @@ class EventEngine {
                 const currentState = this.engine.currentState;
                 const currentContext = this.engine.currentContext;
                 let currentTimetoken = '0';
-                if ((currentState === null || currentState === void 0 ? void 0 : currentState.label) === receiving_1.ReceivingState.label && currentContext) {
+                if ((currentState === null || currentState === void 0 ? void 0 : currentState.label) === states_1.ReceivingState.label && currentContext) {
                     const receivingContext = currentContext;
                     currentTimetoken = (_a = receivingContext.cursor) === null || _a === void 0 ? void 0 : _a.timetoken;
                 }

dist/web/pubnub.min.js

@@ -40,7 +40,7 @@ var __importStar = (this && this.__importStar) || (function () {
 Object.defineProperty(exports, "__esModule", { value: true });
 exports.PresenceEventEngine = void 0;
 const dispatcher_1 = require("./dispatcher");
-const heartbeat_inactive_1 = require("./states/heartbeat_inactive");
+const states_1 = require("./states");
 const core_1 = require("../core");
 const events = __importStar(require("./events"));
 /**
@@ -64,7 +64,7 @@ class PresenceEventEngine {
                 this.dispatcher.dispatch(change.invocation);
             }
         });
-        this.engine.start(heartbeat_inactive_1.HeartbeatInactiveState, undefined);
+        this.engine.start(states_1.HeartbeatInactiveState, undefined);
     }
     join({ channels, groups }) {
         this.channels = [...this.channels, ...(channels !== null && channels !== void 0 ? channels : []).filter((channel) => !this.channels.includes(channel))];

lib/event-engine/index.js

@@ -6,37 +6,34 @@
  */
 Object.defineProperty(exports, "__esModule", { value: true });
 exports.HeartbeatCooldownState = void 0;
-const state_1 = require("../../core/state");
 const events_1 = require("../events");
 const effects_1 = require("../effects");
-const heartbeating_1 = require("./heartbeating");
-const heartbeat_stopped_1 = require("./heartbeat_stopped");
-const heartbeat_inactive_1 = require("./heartbeat_inactive");
+const instances_1 = require("./instances");
+Object.defineProperty(exports, "HeartbeatCooldownState", { enumerable: true, get: function () { return instances_1.HeartbeatCooldownState; } });
 /**
  * Waiting next heartbeat state.
  *
  * State in which Presence Event Engine is waiting when delay will run out and next heartbeat call should be done.
  *
  * @internal
  */
-exports.HeartbeatCooldownState = new state_1.State('HEARTBEAT_COOLDOWN');
-exports.HeartbeatCooldownState.onEnter(() => (0, effects_1.wait)());
-exports.HeartbeatCooldownState.onExit(() => effects_1.wait.cancel);
-exports.HeartbeatCooldownState.on(events_1.timesUp.type, (context, _) => heartbeating_1.HeartbeatingState.with({
+instances_1.HeartbeatCooldownState.onEnter(() => (0, effects_1.wait)());
+instances_1.HeartbeatCooldownState.onExit(() => effects_1.wait.cancel);
+instances_1.HeartbeatCooldownState.on(events_1.timesUp.type, (context, _) => instances_1.HeartbeatingState.with({
     channels: context.channels,
     groups: context.groups,
 }));
-exports.HeartbeatCooldownState.on(events_1.joined.type, (context, event) => heartbeating_1.HeartbeatingState.with({
+instances_1.HeartbeatCooldownState.on(events_1.joined.type, (context, event) => instances_1.HeartbeatingState.with({
     channels: [...context.channels, ...event.payload.channels.filter((channel) => !context.channels.includes(channel))],
     groups: [...context.groups, ...event.payload.groups.filter((group) => !context.groups.includes(group))],
 }));
-exports.HeartbeatCooldownState.on(events_1.left.type, (context, event) => heartbeating_1.HeartbeatingState.with({
+instances_1.HeartbeatCooldownState.on(events_1.left.type, (context, event) => instances_1.HeartbeatingState.with({
     channels: context.channels.filter((channel) => !event.payload.channels.includes(channel)),
     groups: context.groups.filter((group) => !event.payload.groups.includes(group)),
 }, [(0, effects_1.leave)(event.payload.channels, event.payload.groups)]));
-exports.HeartbeatCooldownState.on(events_1.disconnect.type, (context, event) => heartbeat_stopped_1.HeartbeatStoppedState.with({ channels: context.channels, groups: context.groups }, [
+instances_1.HeartbeatCooldownState.on(events_1.disconnect.type, (context, event) => instances_1.HeartbeatStoppedState.with({ channels: context.channels, groups: context.groups }, [
     ...(!event.payload.isOffline ? [(0, effects_1.leave)(context.channels, context.groups)] : []),
 ]));
-exports.HeartbeatCooldownState.on(events_1.leftAll.type, (context, event) => heartbeat_inactive_1.HeartbeatInactiveState.with(undefined, [
+instances_1.HeartbeatCooldownState.on(events_1.leftAll.type, (context, event) => instances_1.HeartbeatInactiveState.with(undefined, [
     ...(!event.payload.isOffline ? [(0, effects_1.leave)(context.channels, context.groups)] : []),
 ]));

lib/event-engine/presence/presence.js

@@ -6,12 +6,10 @@
  */
 Object.defineProperty(exports, "__esModule", { value: true });
 exports.HeartbeatFailedState = void 0;
-const state_1 = require("../../core/state");
 const events_1 = require("../events");
 const effects_1 = require("../effects");
-const heartbeating_1 = require("./heartbeating");
-const heartbeat_stopped_1 = require("./heartbeat_stopped");
-const heartbeat_inactive_1 = require("./heartbeat_inactive");
+const instances_1 = require("./instances");
+Object.defineProperty(exports, "HeartbeatFailedState", { enumerable: true, get: function () { return instances_1.HeartbeatFailedState; } });
 /**
  * Failed to heartbeat state.
  *
@@ -20,22 +18,21 @@ const heartbeat_inactive_1 = require("./heartbeat_inactive");
  *
  * @internal
  */
-exports.HeartbeatFailedState = new state_1.State('HEARTBEAT_FAILED');
-exports.HeartbeatFailedState.on(events_1.joined.type, (context, event) => heartbeating_1.HeartbeatingState.with({
+instances_1.HeartbeatFailedState.on(events_1.joined.type, (context, event) => instances_1.HeartbeatingState.with({
     channels: [...context.channels, ...event.payload.channels.filter((channel) => !context.channels.includes(channel))],
     groups: [...context.groups, ...event.payload.groups.filter((group) => !context.groups.includes(group))],
 }));
-exports.HeartbeatFailedState.on(events_1.left.type, (context, event) => heartbeating_1.HeartbeatingState.with({
+instances_1.HeartbeatFailedState.on(events_1.left.type, (context, event) => instances_1.HeartbeatingState.with({
     channels: context.channels.filter((channel) => !event.payload.channels.includes(channel)),
     groups: context.groups.filter((group) => !event.payload.groups.includes(group)),
 }, [(0, effects_1.leave)(event.payload.channels, event.payload.groups)]));
-exports.HeartbeatFailedState.on(events_1.reconnect.type, (context, _) => heartbeating_1.HeartbeatingState.with({
+instances_1.HeartbeatFailedState.on(events_1.reconnect.type, (context, _) => instances_1.HeartbeatingState.with({
     channels: context.channels,
     groups: context.groups,
 }));
-exports.HeartbeatFailedState.on(events_1.disconnect.type, (context, event) => heartbeat_stopped_1.HeartbeatStoppedState.with({ channels: context.channels, groups: context.groups }, [
+instances_1.HeartbeatFailedState.on(events_1.disconnect.type, (context, event) => instances_1.HeartbeatStoppedState.with({ channels: context.channels, groups: context.groups }, [
     ...(!event.payload.isOffline ? [(0, effects_1.leave)(context.channels, context.groups)] : []),
 ]));
-exports.HeartbeatFailedState.on(events_1.leftAll.type, (context, event) => heartbeat_inactive_1.HeartbeatInactiveState.with(undefined, [
+instances_1.HeartbeatFailedState.on(events_1.leftAll.type, (context, event) => instances_1.HeartbeatInactiveState.with(undefined, [
     ...(!event.payload.isOffline ? [(0, effects_1.leave)(context.channels, context.groups)] : []),
 ]));

lib/event-engine/presence/states/heartbeat_cooldown.js

@@ -6,18 +6,17 @@
  */
 Object.defineProperty(exports, "__esModule", { value: true });
 exports.HeartbeatInactiveState = void 0;
-const state_1 = require("../../core/state");
 const events_1 = require("../events");
-const heartbeating_1 = require("./heartbeating");
+const instances_1 = require("./instances");
+Object.defineProperty(exports, "HeartbeatInactiveState", { enumerable: true, get: function () { return instances_1.HeartbeatInactiveState; } });
 /**
  * Inactive heratbeating state
  *
  * State in which Presence Event Engine doesn't process any heartbeat requests (initial state).
  *
  * @internal
  */
-exports.HeartbeatInactiveState = new state_1.State('HEARTBEAT_INACTIVE');
-exports.HeartbeatInactiveState.on(events_1.joined.type, (_, event) => heartbeating_1.HeartbeatingState.with({
+instances_1.HeartbeatInactiveState.on(events_1.joined.type, (_, event) => instances_1.HeartbeatingState.with({
     channels: event.payload.channels,
     groups: event.payload.groups,
 }));

lib/event-engine/presence/states/heartbeat_failed.js

@@ -6,10 +6,9 @@
  */
 Object.defineProperty(exports, "__esModule", { value: true });
 exports.HeartbeatStoppedState = void 0;
-const state_1 = require("../../core/state");
 const events_1 = require("../events");
-const heartbeat_inactive_1 = require("./heartbeat_inactive");
-const heartbeating_1 = require("./heartbeating");
+const instances_1 = require("./instances");
+Object.defineProperty(exports, "HeartbeatStoppedState", { enumerable: true, get: function () { return instances_1.HeartbeatStoppedState; } });
 /**
  * Heartbeat stopped state.
  *
@@ -18,17 +17,16 @@ const heartbeating_1 = require("./heartbeating");
  *
  * @internal
  */
-exports.HeartbeatStoppedState = new state_1.State('HEARTBEAT_STOPPED');
-exports.HeartbeatStoppedState.on(events_1.joined.type, (context, event) => exports.HeartbeatStoppedState.with({
+instances_1.HeartbeatStoppedState.on(events_1.joined.type, (context, event) => instances_1.HeartbeatStoppedState.with({
     channels: [...context.channels, ...event.payload.channels.filter((channel) => !context.channels.includes(channel))],
     groups: [...context.groups, ...event.payload.groups.filter((group) => !context.groups.includes(group))],
 }));
-exports.HeartbeatStoppedState.on(events_1.left.type, (context, event) => exports.HeartbeatStoppedState.with({
+instances_1.HeartbeatStoppedState.on(events_1.left.type, (context, event) => instances_1.HeartbeatStoppedState.with({
     channels: context.channels.filter((channel) => !event.payload.channels.includes(channel)),
     groups: context.groups.filter((group) => !event.payload.groups.includes(group)),
 }));
-exports.HeartbeatStoppedState.on(events_1.reconnect.type, (context, _) => heartbeating_1.HeartbeatingState.with({
+instances_1.HeartbeatStoppedState.on(events_1.reconnect.type, (context, _) => instances_1.HeartbeatingState.with({
     channels: context.channels,
     groups: context.groups,
 }));
-exports.HeartbeatStoppedState.on(events_1.leftAll.type, (context, _) => heartbeat_inactive_1.HeartbeatInactiveState.with(undefined));
+instances_1.HeartbeatStoppedState.on(events_1.leftAll.type, (context, _) => instances_1.HeartbeatInactiveState.with(undefined));

lib/event-engine/presence/states/heartbeat_inactive.js

@@ -7,41 +7,37 @@
 Object.defineProperty(exports, "__esModule", { value: true });
 exports.HeartbeatingState = void 0;
 const events_1 = require("../events");
-const heartbeat_inactive_1 = require("./heartbeat_inactive");
-const heartbeat_cooldown_1 = require("./heartbeat_cooldown");
-const heartbeat_stopped_1 = require("./heartbeat_stopped");
-const heartbeat_failed_1 = require("./heartbeat_failed");
 const effects_1 = require("../effects");
-const state_1 = require("../../core/state");
+const instances_1 = require("./instances");
+Object.defineProperty(exports, "HeartbeatingState", { enumerable: true, get: function () { return instances_1.HeartbeatingState; } });
 /**
  * Heartbeating state module.
  *
  * State in which Presence Event Engine send heartbeat REST API call.
  *
  * @internal
  */
-exports.HeartbeatingState = new state_1.State('HEARTBEATING');
-exports.HeartbeatingState.onEnter((context) => (0, effects_1.heartbeat)(context.channels, context.groups));
-exports.HeartbeatingState.onExit(() => effects_1.heartbeat.cancel);
-exports.HeartbeatingState.on(events_1.heartbeatSuccess.type, (context, event) => heartbeat_cooldown_1.HeartbeatCooldownState.with({ channels: context.channels, groups: context.groups }, [
+instances_1.HeartbeatingState.onEnter((context) => (0, effects_1.heartbeat)(context.channels, context.groups));
+instances_1.HeartbeatingState.onExit(() => effects_1.heartbeat.cancel);
+instances_1.HeartbeatingState.on(events_1.heartbeatSuccess.type, (context, event) => instances_1.HeartbeatCooldownState.with({ channels: context.channels, groups: context.groups }, [
     (0, effects_1.emitStatus)(Object.assign({}, event.payload)),
 ]));
-exports.HeartbeatingState.on(events_1.joined.type, (context, event) => exports.HeartbeatingState.with({
+instances_1.HeartbeatingState.on(events_1.joined.type, (context, event) => instances_1.HeartbeatingState.with({
     channels: [...context.channels, ...event.payload.channels.filter((channel) => !context.channels.includes(channel))],
     groups: [...context.groups, ...event.payload.groups.filter((group) => !context.groups.includes(group))],
 }));
-exports.HeartbeatingState.on(events_1.left.type, (context, event) => {
-    return exports.HeartbeatingState.with({
+instances_1.HeartbeatingState.on(events_1.left.type, (context, event) => {
+    return instances_1.HeartbeatingState.with({
         channels: context.channels.filter((channel) => !event.payload.channels.includes(channel)),
         groups: context.groups.filter((group) => !event.payload.groups.includes(group)),
     }, [(0, effects_1.leave)(event.payload.channels, event.payload.groups)]);
 });
-exports.HeartbeatingState.on(events_1.heartbeatFailure.type, (context, event) => heartbeat_failed_1.HeartbeatFailedState.with(Object.assign({}, context), [
+instances_1.HeartbeatingState.on(events_1.heartbeatFailure.type, (context, event) => instances_1.HeartbeatFailedState.with(Object.assign({}, context), [
     ...(event.payload.status ? [(0, effects_1.emitStatus)(Object.assign({}, event.payload.status))] : []),
 ]));
-exports.HeartbeatingState.on(events_1.disconnect.type, (context, event) => heartbeat_stopped_1.HeartbeatStoppedState.with({ channels: context.channels, groups: context.groups }, [
+instances_1.HeartbeatingState.on(events_1.disconnect.type, (context, event) => instances_1.HeartbeatStoppedState.with({ channels: context.channels, groups: context.groups }, [
     ...(!event.payload.isOffline ? [(0, effects_1.leave)(context.channels, context.groups)] : []),
 ]));
-exports.HeartbeatingState.on(events_1.leftAll.type, (context, event) => heartbeat_inactive_1.HeartbeatInactiveState.with(undefined, [
+instances_1.HeartbeatingState.on(events_1.leftAll.type, (context, event) => instances_1.HeartbeatInactiveState.with(undefined, [
     ...(!event.payload.isOffline ? [(0, effects_1.leave)(context.channels, context.groups)] : []),
 ]));

lib/event-engine/presence/states/heartbeat_stopped.js

@@ -0,0 +1,21 @@
+"use strict";
+/**
+ * Presence Event Engine states.
+ *
+ * Side-effect imports register transition handlers on the shared state instances.
+ *
+ * @internal
+ */
+Object.defineProperty(exports, "__esModule", { value: true });
+exports.HeartbeatFailedState = exports.HeartbeatStoppedState = exports.HeartbeatCooldownState = exports.HeartbeatingState = exports.HeartbeatInactiveState = void 0;
+require("./heartbeat_inactive");
+require("./heartbeating");
+require("./heartbeat_cooldown");
+require("./heartbeat_stopped");
+require("./heartbeat_failed");
+var instances_1 = require("./instances");
+Object.defineProperty(exports, "HeartbeatInactiveState", { enumerable: true, get: function () { return instances_1.HeartbeatInactiveState; } });
+Object.defineProperty(exports, "HeartbeatingState", { enumerable: true, get: function () { return instances_1.HeartbeatingState; } });
+Object.defineProperty(exports, "HeartbeatCooldownState", { enumerable: true, get: function () { return instances_1.HeartbeatCooldownState; } });
+Object.defineProperty(exports, "HeartbeatStoppedState", { enumerable: true, get: function () { return instances_1.HeartbeatStoppedState; } });
+Object.defineProperty(exports, "HeartbeatFailedState", { enumerable: true, get: function () { return instances_1.HeartbeatFailedState; } });