pubnub-redux - npm Package Compare versions

Comparing version 0.1.12-alpha to 0.1.14-alpha

dist/index.d.ts

@@ -21,2 +21,3 @@ import { createPubNubActionListener, combineListeners } from './listeners/PubNubListener';
 import { createMembershipReducer } from './reducers/membershipReducer';
+import { createMembersReducer } from './reducers/membersReducer';
 import { Identifiable, PubNubObjectApiState } from './api/PubNubApi';
@@ -27,2 +28,2 @@ import { Space } from './api/Space';
 import { UserListState } from './reducers/userListReducer';
-export { Identifiable, PubNubObjectApiState as PubNubApiState, Space, SpaceListState, User, UserListState, createPubNubActionListener, createMembershipActionListener, fetchMembers, updateMembers, addMembers, removeMembers, fetchMemberships, updateMembership, joinSpaces, leaveSpaces, createMessageActionListener, createPresenceActionListener, userJoin, userLeave, userStateChange, userTimeout, createSignalActionListener, createSpaceActionListener, spaceDeleted, spaceUpdated, fetchSpaces, spaceListRetrieved, fetchSpacesError, createSpace, fetchSpaceById, createNetworkStatusActionListener, createSubscribeStatusActionListener, createErrorStatusActionListener, networkDown, networkUp, networkIssues, reconnected, connected, timeoutConnection, accessDenied, malformedResponse, badRequest, decryptionError, requestMessageCountExceed, unknown, createUserActionListener, userUpdated, userDeleted, createUser, fetchUsers, fetchUserById, userListRetrieved, fetchUsersError, createNetworkStatusReducer, createUserReducer, createUserListReducer, createSpaceReducer, createSpaceListReducer, createMembershipReducer, combineListeners, };
+export { Identifiable, PubNubObjectApiState as PubNubApiState, Space, SpaceListState, User, UserListState, createPubNubActionListener, createMembershipActionListener, fetchMembers, updateMembers, addMembers, removeMembers, fetchMemberships, updateMembership, joinSpaces, leaveSpaces, createMessageActionListener, createPresenceActionListener, userJoin, userLeave, userStateChange, userTimeout, createSignalActionListener, createSpaceActionListener, spaceDeleted, spaceUpdated, fetchSpaces, spaceListRetrieved, fetchSpacesError, createSpace, fetchSpaceById, createNetworkStatusActionListener, createSubscribeStatusActionListener, createErrorStatusActionListener, networkDown, networkUp, networkIssues, reconnected, connected, timeoutConnection, accessDenied, malformedResponse, badRequest, decryptionError, requestMessageCountExceed, unknown, createUserActionListener, userUpdated, userDeleted, createUser, fetchUsers, fetchUserById, userListRetrieved, fetchUsersError, createNetworkStatusReducer, createUserReducer, createUserListReducer, createSpaceReducer, createSpaceListReducer, createMembershipReducer, createMembersReducer, combineListeners, };

dist/pubnub-redux.cjs.development.js

@@ -1928,2 +1928,222 @@ 'use strict';
 
+var createInitialState$5 = function createInitialState() {
+  return {
+    byId: {},
+    loadingById: {},
+    errorById: {}
+  };
+};
+
+var userAddedToSpace$2 = function userAddedToSpace(state, payload) {
+  var newState = _extends({}, state);
+
+  Object.keys(newState.byId).forEach(function (key) {
+    newState.byId[key] = [].concat(newState.byId[key]);
+  });
+  var currentValue = newState.byId[payload.data.userId];
+
+  if (currentValue === undefined) {
+    newState.byId[payload.data.userId] = [{
+      id: payload.data.spaceId
+    }];
+  } else if (currentValue.filter(function (item) {
+    return item.id === payload.data.spaceId;
+  }).length === 0) {
+    currentValue.push({
+      id: payload.data.spaceId
+    });
+  }
+
+  return newState;
+};
+
+var userRemovedFromSpace$2 = function userRemovedFromSpace(state, payload) {
+  var newState = _extends({}, state);
+
+  Object.keys(newState.byId).forEach(function (key) {
+    newState.byId[key] = [].concat(state.byId[key]);
+  });
+  var currentValue = newState.byId[payload.data.userId];
+
+  if (currentValue !== undefined) {
+    newState.byId[payload.data.userId] = newState.byId[payload.data.userId].filter(function (item) {
+      return item.id !== payload.data.spaceId;
+    });
+  }
+
+  return newState;
+};
+
+var userMembersUpdatedOnSpace = function userMembersUpdatedOnSpace(state, payload) {
+  var newState = _extends({}, state);
+
+  Object.keys(newState.byId).forEach(function (key) {
+    newState.byId[key] = [].concat(state.byId[key]);
+  });
+  var currentValue = newState.byId[payload.data.userId];
+
+  if (currentValue !== undefined) {
+    var existing = newState.byId[payload.data.userId].filter(function (item) {
+      return item.id === payload.data.spaceId;
+    });
+
+    if (existing.length > 0) ;
+  }
+
+  return newState;
+};
+
+var beginFetchMembers = function beginFetchMembers(state, payload) {
+  var newState = _extends({}, state);
+
+  Object.keys(newState.byId).forEach(function (key) {
+    newState.byId[key] = [].concat(state.byId[key]);
+  }); // increment loading count or set to 1
+
+  newState.loadingById[payload] = newState.loadingById[payload] !== undefined ? newState.loadingById[payload] + 1 : 1; // clear error
+
+  delete newState.errorById[payload];
+  return newState;
+};
+
+var fetchMembers$2 = function fetchMembers(state, payload) {
+  var newState = _extends({}, state);
+
+  Object.keys(newState.byId).forEach(function (key) {
+    newState.byId[key] = [].concat(state.byId[key]);
+  });
+  var id = payload.data.id; // decrement loading count or set to 0
+
+  newState.loadingById[id] = newState.loadingById[id] > 0 ? newState.loadingById[id] - 1 : 0; // set response payload
+
+  newState.byId[id] = [].concat(payload.data.users);
+  return newState;
+};
+
+var fetchMembersError$1 = function fetchMembersError(state, payload) {
+  var newState = _extends({}, state);
+
+  Object.keys(newState.byId).forEach(function (key) {
+    newState.byId[key] = [].concat(state.byId[key]);
+  });
+
+  if (payload.data.id) {
+    var id = payload.data.id; // decrement loading count or set to 0
+
+    newState.loadingById[id] = newState.loadingById[id] > 0 ? newState.loadingById[id] - 1 : 0; // set error payload
+
+    newState.errorById[id] = payload;
+  }
+
+  return newState;
+};
+
+var beginUpdateMembers = function beginUpdateMembers(state, payload) {
+  return beginObjectById(state, payload);
+};
+
+var updateMembers$1 = function updateMembers(state, payload) {
+  return successObjectById(state, {
+    data: payload.data.users
+  }, payload.data.spaceId);
+};
+
+var updateMembersError$1 = function updateMembersError(state, payload) {
+  return errorObjectById(state, payload, payload.data.id);
+};
+
+var beginAddMembers = function beginAddMembers(state, payload) {
+  return beginObjectById(state, payload);
+};
+
+var addMembers$1 = function addMembers(state, payload) {
+  return successObjectById(state, {
+    data: payload.data.users
+  }, payload.data.spaceId);
+};
+
+var addMembersError$1 = function addMembersError(state, payload) {
+  return errorObjectById(state, payload, payload.data.id);
+};
+
+var beginRemoveMembers = function beginRemoveMembers(state, payload) {
+  return beginObjectById(state, payload);
+};
+
+var removeMembers$1 = function removeMembers(state, payload) {
+  return successObjectById(state, {
+    data: payload.data.users
+  }, payload.data.spaceId);
+};
+
+var removeMembersError$1 = function removeMembersError(state, payload) {
+  return errorObjectById(state, payload, payload.data.id);
+};
+
+var createMembersReducer = function createMembersReducer() {
+  return function (state, action) {
+    if (state === void 0) {
+      state = createInitialState$5();
+    }
+
+    switch (action.type) {
+      case actionType.OBJECTS_USER_ADDED_TO_SPACE:
+        return userAddedToSpace$2(state, action.payload);
+
+      case actionType.OBJECTS_USER_REMOVED_FROM_SPACE:
+        return userRemovedFromSpace$2(state, action.payload);
+
+      case actionType.OBJECTS_USER_MEMBERSHIP_UPDATED_ON_SPACE:
+        return userMembersUpdatedOnSpace(state, action.payload);
+
+      case actionType.OBJECTS_FETCH_MEMBERS_BEGIN:
+        return beginFetchMembers(state, action.payload);
+
+      case actionType.OBJECTS_FETCH_MEMBERS:
+        return fetchMembers$2(state, action.payload);
+
+      case actionType.OBJECTS_FETCH_MEMBERS_ERROR:
+        return fetchMembersError$1(state, action.payload);
+
+      case actionType.OBJECTS_UPDATE_MEMBERS_BEGIN:
+        return beginUpdateMembers(state, action.payload);
+
+      case actionType.OBJECTS_UPDATE_MEMBERS:
+        return updateMembers$1(state, action.payload);
+
+      case actionType.OBJECTS_UPDATE_MEMBERS_ERROR:
+        return updateMembersError$1(state, action.payload);
+
+      case actionType.OBJECTS_ADD_MEMBERS_BEGIN:
+        return beginAddMembers(state, action.payload);
+
+      case actionType.OBJECTS_MEMBERS_ADDED:
+        return addMembers$1(state, action.payload);
+
+      case actionType.OBJECTS_ADD_MEMBERS_ERROR:
+        return addMembersError$1(state, action.payload);
+
+      case actionType.OBJECTS_REMOVE_MEMBERS_BEGIN:
+        return beginRemoveMembers(state, action.payload);
+
+      case actionType.OBJECTS_MEMBERS_REMOVED:
+        return removeMembers$1(state, action.payload);
+
+      case actionType.OBJECTS_REMOVE_MEMBERS_ERROR:
+        return removeMembersError$1(state, action.payload);
+
+      default:
+        return state;
+    }
+  };
+}; //   | UpdateMembersBeginAction<T>
+//   | MembersUpdatedAction<T>
+//   | UpdateMembersErrorAction<T>
+//   | JoinSpacesBeginAction<T>
+//   | SpacesJoinedAction<T>
+//   | JoinSpacesErrorAction<T>
+//   | LeaveSpacesBeginAction<T>
+//   | SpacesLeftAction<T>
+//   | LeaveSpacesErrorAction<T>;
+
 exports.accessDenied = accessDenied;
@@ -1935,2 +2155,3 @@ exports.addMembers = addMembers;
 exports.createErrorStatusActionListener = createErrorStatusActionListener;
+exports.createMembersReducer = createMembersReducer;
 exports.createMembershipActionListener = createMembershipActionListener;
@@ -1937,0 +2158,0 @@ exports.createMembershipReducer = createMembershipReducer;

dist/pubnub-redux.cjs.production.min.js

@@ -1,2 +0,2 @@
-"use strict";var E;!function(E){E.MESSAGE="pubnub/MESSAGE",E.JOIN="pubnub/JOIN",E.LEAVE="pubnub/LEAVE",E.TIMEOUT="pubnub/TIMEOUT",E.STATE_CHANGE="pubnub/STATE_CHANGE",E.NETWORK_UP="pubnub/NETWORK_UP",E.NETWORK_DOWN="pubnub/NETWORK_DOWN",E.NETWORK_ISSUES="pubnub/NETWORK_ISSUES",E.RECONNECTED="pubnub/RECONNECTED",E.CONNECTED="pubnub/CONNECTED",E.ACCESS_DENIED="pubnub/ACCESS_DENIED",E.MALFORMED_RESPONSE="pubnub/MALFORMED_RESPONSE",E.BAD_REQUEST="pubnub/BAD_REQUEST",E.DECRYPTION_ERROR="pubnub/DECRYPTION_ERROR",E.TIMEOUT_CONNECTION="pubnub/TIMEOUT_CONNECTION",E.REQUEST_MESSAGE_COUNT_EXCEED="pubnub/REQUEST_MESSAGE_COUNT_EXCEED",E.UNKNOWN="pubnub/UNKNOWN",E.OBJECTS_UPDATE_USER_BEGIN="pubnub/OBJECTS_UPDATE_USER_BEGIN",E.OBJECTS_UPDATE_USER="pubnub/OBJECTS_UPDATE_USER",E.OBJECTS_UPDATE_USER_ERROR="pubnub/OBJECTS_UPDATE_USER_ERROR",E.OBJECTS_DELETE_USER_BEGIN="pubnub/OBJECTS_DELETE_USER_BEGIN",E.OBJECTS_DELETE_USER="pubnub/OBJECTS_DELETE_USER",E.OBJECTS_DELETE_USER_ERROR="pubnub/OBJECTS_DELETE_USER_ERROR",E.OBJECTS_CREATE_USER_BEGIN="pubnub/OBJECTS_CREATE_USER_BEGIN",E.OBJECTS_CREATE_USER="pubnub/OBJECTS_CREATE_USER",E.OBJECTS_CREATE_USER_ERROR="pubnub/OBJECTS_CREATE_USER_ERROR",E.OBJECTS_FETCH_USERS_BEGIN="pubnub/OBJECTS_FETCH_USERS_BEGIN",E.OBJECTS_FETCH_USERS="pubnub/OBJECTS_FETCH_USERS",E.OBJECTS_FETCH_USERS_ERROR="pubnub/OBJECTS_FETCH_USERS_ERROR",E.OBJECTS_FETCH_USER_BY_ID_BEGIN="pubnub/OBJECTS_FETCH_USER_BY_ID_BEGIN",E.OBJECTS_FETCH_USER_BY_ID="pubnub/OBJECTS_FETCH_USER_BY_ID",E.OBJECTS_FETCH_USER_BY_ID_ERROR="pubnub/OBJECTS_FETCH_USER_BY_ID_ERROR",E.OBJECTS_CREATE_SPACE="pubnub/OBJECTS_CREATE_SPACE",E.OBJECTS_CREATE_SPACE_BEGIN="pubnub/OBJECTS_CREATE_SPACE_BEGIN",E.OBJECTS_CREATE_SPACE_ERROR="pubnub/OBJECTS_CREATE_SPACE_ERROR",E.OBJECTS_UPDATE_SPACE="pubnub/OBJECTS_UPDATE_SPACE",E.OBJECTS_UPDATE_SPACE_BEGIN="pubnub/OBJECTS_UPDATE_SPACE_BEGIN",E.OBJECTS_UPDATE_SPACE_ERROR="pubnub/OBJECTS_UPDATE_SPACE_ERROR",E.OBJECTS_DELETE_SPACE="pubnub/OBJECTS_DELETE_SPACE",E.OBJECTS_DELETE_SPACE_BEGIN="pubnub/OBJECTS_DELETE_SPACE_BEGIN",E.OBJECTS_DELETE_SPACE_ERROR="pubnub/OBJECTS_DELETE_SPACE_ERROR",E.OBJECTS_FETCH_SPACES="pubnub/OBJECTS_FETCH_SPACES",E.OBJECTS_FETCH_SPACES_BEGIN="pubnub/OBJECTS_FETCH_SPACES_BEGIN",E.OBJECTS_FETCH_SPACES_ERROR="pubnub/OBJECTS_FETCH_SPACES_ERROR",E.OBJECTS_FETCH_SPACE_BY_ID="pubnub/OBJECTS_FETCH_SPACE_BY_ID",E.OBJECTS_FETCH_SPACE_BY_ID_BEGIN="pubnub/OBJECTS_FETCH_SPACE_BY_ID_BEGIN",E.OBJECTS_FETCH_SPACE_BY_ID_ERROR="pubnub/OBJECTS_FETCH_SPACE_BY_ID_ERROR",E.OBJECTS_USER_ADDED_TO_SPACE="pubnub/OBJECTS_USER_ADDED_TO_SPACE",E.OBJECTS_USER_REMOVED_FROM_SPACE="pubnub/OBJECTS_USER_REMOVED_FROM_SPACE",E.OBJECTS_USER_MEMBERSHIP_UPDATED_ON_SPACE="pubnub/OBJECTS_USER_MEMBERSHIP_UPDATED_ON_SPACE",E.OBJECTS_FETCH_MEMBERS_BEGIN="pubnub/OBJECTS_FETCH_MEMBERS_BEGIN",E.OBJECTS_FETCH_MEMBERS="pubnub/OBJECTS_FETCH_MEMBERS",E.OBJECTS_FETCH_MEMBERS_ERROR="pubnub/OBJECTS_FETCH_MEMBERS_ERROR",E.OBJECTS_UPDATE_MEMBERS_BEGIN="pubnub/OBJECTS_UPDATE_MEMBERS_BEGIN",E.OBJECTS_UPDATE_MEMBERS="pubnub/OBJECTS_UPDATE_MEMBERS",E.OBJECTS_UPDATE_MEMBERS_ERROR="pubnub/OBJECTS_UPDATE_MEMBERS_ERROR",E.OBJECTS_ADD_MEMBERS_BEGIN="pubnub/OBJECTS_ADD_MEMBERS_BEGIN",E.OBJECTS_MEMBERS_ADDED="pubnub/OBJECTS_MEMBERS_ADDED",E.OBJECTS_ADD_MEMBERS_ERROR="pubnub/OBJECTS_ADD_MEMBERS_ERROR",E.OBJECTS_REMOVE_MEMBERS_BEGIN="pubnub/OBJECTS_REMOVE_MEMBERS_BEGIN",E.OBJECTS_MEMBERS_REMOVED="pubnub/OBJECTS_MEMBERS_REMOVED",E.OBJECTS_REMOVE_MEMBERS_ERROR="pubnub/OBJECTS_REMOVE_MEMBERS_ERROR",E.OBJECTS_FETCH_MEMBERSHIPS_BEGIN="pubnub/OBJECTS_FETCH_MEMBERSHIPS_BEGIN",E.OBJECTS_FETCH_MEMBERSHIPS="pubnub/OBJECTS_FETCH_MEMBERSHIPS",E.OBJECTS_FETCH_MEMBERSHIPS_ERROR="pubnub/OBJECTS_FETCH_MEMBERSHIPS_ERROR",E.OBJECTS_UPDATE_MEMBERSHIP_BEGIN="pubnub/OBJECTS_UPDATE_MEMBERSHIP_BEGIN",E.OBJECTS_UPDATE_MEMBERSHIP="pubnub/OBJECTS_UPDATE_MEMBERSHIP",E.OBJECTS_UPDATE_MEMBERSHIP_ERROR="pubnub/OBJECTS_UPDATE_MEMBERSHIP_ERROR",E.OBJECTS_JOIN_SPACES_BEGIN="pubnub/OBJECTS_JOIN_SPACES_BEGIN",E.OBJECTS_SPACES_JOINED="pubnub/OBJECTS_SPACES_JOINED",E.OBJECTS_JOIN_SPACES_ERROR="pubnub/OBJECTS_JOIN_SPACES_ERROR",E.OBJECTS_LEAVE_SPACES_BEGIN="pubnub/OBJECTS_LEAVE_SPACES_BEGIN",E.OBJECTS_SPACES_LEFT="pubnub/OBJECTS_SPACES_LEFT",E.OBJECTS_LEAVE_SPACES_ERROR="pubnub/OBJECTS_LEAVE_SPACES_ERROR",E.SIGNAL="pubnub/SIGNAL"}(E||(E={}));var e=function(e){return{type:E.JOIN,payload:e}},a=function(e){return{type:E.LEAVE,payload:e}},t=function(e){return{type:E.TIMEOUT,payload:e}},r=function(e){return{type:E.STATE_CHANGE,payload:e}},n=function(E){return{presence:function(n){switch(n.action){case"join":E(e(n));break;case"leave":E(a(n));break;case"timeout":E(t(n));break;case"state-change":E(r(n))}}}},_=function(){return{type:E.NETWORK_UP}},o=function(){return{type:E.NETWORK_DOWN}},u=function(E){return{status:function(e){switch(e.category){case"PNNetworkUpCategory":E(_());break;case"PNNetworkDownCategory":case"PNNetworkIssuesCategory":E(o());break;case"PNReconnectedCategory":case"PNConnectedCategory":E(_());break;case"PNTimeoutCategory":E(o())}}}},S=function(e){return{type:E.RECONNECTED,payload:e}},d=function(e){return{type:E.CONNECTED,payload:e}},c=function(E){return{status:function(e){switch(e.category){case"PNReconnectedCategory":E(S(e));break;case"PNConnectedCategory":E(d(e))}}}},C=function(e){return{type:E.NETWORK_ISSUES,payload:e}},T=function(e){return{type:E.ACCESS_DENIED,payload:e}},R=function(e){return{type:E.MALFORMED_RESPONSE,payload:e}},p=function(e){return{type:E.BAD_REQUEST,payload:e}},s=function(e){return{type:E.DECRYPTION_ERROR,payload:e}},i=function(e){return{type:E.TIMEOUT_CONNECTION,payload:e}},B=function(e){return{type:E.REQUEST_MESSAGE_COUNT_EXCEED,payload:e}},O=function(e){return{type:E.UNKNOWN,payload:e}},y=function(E){return{status:function(e){switch(e.category){case"PNNetworkIssuesCategory":E(C(e));break;case"PNAccessDeniedCategory":E(T(e));break;case"PNMalformedResponseCategory":E(R(e));break;case"PNBadRequestCategory":E(p(e));break;case"PNDecryptionErrorCategory":E(s(e));break;case"PNTimeoutCategory":E(i(e));break;case"PNRequestMessageCountExceedCategory":E(B(e));break;case"PNUnknownCategory":E(O(e))}}}},b=function(e){return{message:function(a){return e({type:E.MESSAGE,payload:a})}}},I=function(e){return{signal:function(a){return e({type:E.SIGNAL,payload:a})}}},l=function(e){return{user:function(a){switch(a.message.event){case"update":e(function(e){return{type:E.OBJECTS_UPDATE_USER,payload:e}}({data:a.message.data}));break;case"delete":e(function(e){return{type:E.OBJECTS_DELETE_USER,payload:e}}({data:a.message.data}))}}}},f=function(e){return{space:function(a){switch(a.message.event){case"update":e(function(e){return{type:E.OBJECTS_UPDATE_SPACE,payload:e}}({data:a.message.data}));break;case"delete":e(function(e){return{type:E.OBJECTS_DELETE_SPACE,payload:e}}({data:a.message.data}))}}}},J=function(e){return{membership:function(a){var t={id:a.message.data.userId+"_"+a.message.data.spaceId,data:a.message.data};switch(a.message.event){case"create":e({type:E.OBJECTS_USER_ADDED_TO_SPACE,payload:t});break;case"update":e({type:E.OBJECTS_USER_MEMBERSHIP_UPDATED_ON_SPACE,payload:t});break;case"delete":e({type:E.OBJECTS_USER_REMOVED_FROM_SPACE,payload:t})}}}},A=function(){for(var E=arguments.length,e=new Array(E),a=0;a<E;a++)e[a]=arguments[a];return Object.assign.apply(Object,[{}].concat(P(e)))},P=function(E){var e=[],a={};return E.forEach(function(E){var e=Object.keys(E)[0];a.hasOwnProperty(e)||(a[e]=[]),a[e].push(E)}),Object.entries(a).forEach(function(E){var a=E[0],t=E[1];1===t.length?e.push(t[0]):t.length>1&&e.push(D(a,t))}),e},D=function(E,e){var a;return(a={})[E]=function(a){e.forEach(function(e){console.log("any event",JSON.stringify(a)),e[E](a)})},a};function M(){return(M=Object.assign||function(E){for(var e=1;e<arguments.length;e++){var a=arguments[e];for(var t in a)Object.prototype.hasOwnProperty.call(a,t)&&(E[t]=a[t])}return E}).apply(this,arguments)}var N=function(e){return{type:E.OBJECTS_FETCH_SPACES,payload:e}},U=function(e){return{type:E.OBJECTS_FETCH_SPACES_ERROR,payload:e}},g=function(e){return{type:E.OBJECTS_FETCH_USERS,payload:e}},H=function(e){return{type:E.OBJECTS_FETCH_USERS_ERROR,payload:e}},v=function(E,e){var a=L(E);return a.loadingById[e]=void 0!==a.loadingById[e]?a.loadingById[e]+1:1,delete a.errorById[e],a},F=function(E,e,a){var t=L(E);return t.loadingById[a]=t.loadingById[a]>0?t.loadingById[a]-1:0,t.errorById[a]=e,t},G=function(E,e,a){var t=L(E);return t.loadingById[a]=t.loadingById[a]>0?t.loadingById[a]-1:0,"[object Array]"===Object.prototype.toString.call(e.data)?t.byId[a]=k(e.data):"object"==typeof e.data&&(t.byId[a]=x(e.data)),t},m=function(E,e){var a=L(E);return a.byId=M({},a.byId,{},x(e.data)),a},h=function(E,e){var a=L(E);return a.loadingById[e]=a.loadingById[e]>0?a.loadingById[e]-1:0,delete a.byId[e],a},L=function(E){var e={byId:{},loadingById:M({},E.loadingById),errorById:{}};return Object.keys(E.byId).forEach(function(a){"[object Array]"===Object.prototype.toString.call(E.byId[a])?e.byId[a]=k(E.byId[a]):"object"==typeof E.byId[a]&&(e.byId[a]=x(E.byId[a]))}),Object.keys(E.errorById).forEach(function(a){e.errorById[a]=x(E.errorById[a])}),e},x=function E(e){var a=M({},e);for(var t in e)e.hasOwnProperty(t)&&("[object Array]"===Object.prototype.toString.call(e[t])?a[t]=k(e[t]):"object"==typeof e[t]&&(a[t]=E(e[t])));return a},k=function E(e){for(var a=[].concat(e),t=0;t<a.length;t++){var r=a[t];"[object Array]"===Object.prototype.toString.call(r)?a[t]=E(r):"object"==typeof a[t]&&(a[t]=x(r))}return a};exports.accessDenied=T,exports.addMembers=function(e,a){return function(t){t({type:E.OBJECTS_ADD_MEMBERS_BEGIN,payload:a}),e.addMembers(M({},a),function(e,r){if(e.error){var n={id:a.spaceId,value:M({},a)};t({type:E.OBJECTS_ADD_MEMBERS_ERROR,payload:{code:e.category,message:e.errorData,data:n}})}else t({type:E.OBJECTS_MEMBERS_ADDED,payload:{data:r.data}})})}},exports.badRequest=p,exports.combineListeners=A,exports.connected=d,exports.createErrorStatusActionListener=y,exports.createMembershipActionListener=J,exports.createMembershipReducer=function(){return function(e,a){switch(void 0===e&&(e={byId:{},loadingById:{},errorById:{}}),a.type){case E.OBJECTS_USER_ADDED_TO_SPACE:return function(E,e){var a=M({},E);console.log("user added to space",JSON.stringify(e)),Object.keys(a.byId).forEach(function(E){a.byId[E]=[].concat(a.byId[E])});var t=a.byId[e.data.userId];return void 0===t?a.byId[e.data.userId]=[{id:e.data.spaceId}]:0===t.filter(function(E){return E.id===e.data.spaceId}).length&&t.push({id:e.data.spaceId}),a}(e,a.payload);case E.OBJECTS_USER_REMOVED_FROM_SPACE:return function(E,e){var a=M({},E);return Object.keys(a.byId).forEach(function(e){a.byId[e]=[].concat(E.byId[e])}),void 0!==a.byId[e.data.userId]&&(a.byId[e.data.userId]=a.byId[e.data.userId].filter(function(E){return E.id!==e.data.spaceId})),a}(e,a.payload);case E.OBJECTS_USER_MEMBERSHIP_UPDATED_ON_SPACE:return function(E,e){var a=M({},E);return Object.keys(a.byId).forEach(function(e){a.byId[e]=[].concat(E.byId[e])}),void 0!==a.byId[e.data.userId]&&a.byId[e.data.userId].filter(function(E){return E.id===e.data.spaceId}),a}(e,a.payload);case E.OBJECTS_FETCH_MEMBERSHIPS_BEGIN:return function(E,e){return v(E,a.payload)}(e);case E.OBJECTS_FETCH_MEMBERSHIPS:return function(E,e){return G(E,{data:e.data.spaces},e.data.id)}(e,a.payload);case E.OBJECTS_FETCH_MEMBERSHIPS_ERROR:return function(E,e){return F(E,{code:e.code,message:e.message,data:{id:e.data.id}},e.data.id)}(e,a.payload);case E.OBJECTS_UPDATE_MEMBERSHIP_BEGIN:return function(E,e){return v(E,a.payload)}(e);case E.OBJECTS_UPDATE_MEMBERSHIP:return function(E,e){return G(E,{data:e.data.spaces},e.data.userId)}(e,a.payload);case E.OBJECTS_UPDATE_MEMBERSHIP_ERROR:return function(E,e){return F(E,e,e.data.id)}(e,a.payload);case E.OBJECTS_JOIN_SPACES_BEGIN:return function(E,e){return v(E,a.payload)}(e);case E.OBJECTS_SPACES_JOINED:return function(E,e){return G(E,{data:e.data.spaces},e.data.userId)}(e,a.payload);case E.OBJECTS_JOIN_SPACES_ERROR:return function(E,e){return F(E,e,e.data.id)}(e,a.payload);case E.OBJECTS_LEAVE_SPACES_BEGIN:return function(E,e){return v(E,a.payload)}(e);case E.OBJECTS_SPACES_LEFT:return function(E,e){return G(E,{data:e.data.spaces},e.data.userId)}(e,a.payload);case E.OBJECTS_LEAVE_SPACES_ERROR:return function(E,e){return F(E,e,e.data.id)}(e,a.payload);default:return e}}},exports.createMessageActionListener=b,exports.createNetworkStatusActionListener=u,exports.createNetworkStatusReducer=function(e){var a;if("boolean"==typeof e)a={isConnected:e};else{if("function"!=typeof e)throw new Error("The initializer parameter must be a boolean value (true or false) or function");if("boolean"!=typeof(a={isConnected:e()}).isConnected)throw new Error("The initializer function must return a boolean value (true or false)")}return function(e,t){switch(void 0===e&&(e=a),t.type){case E.NETWORK_UP:return M({},e,{isConnected:!0});case E.NETWORK_DOWN:return M({},e,{isConnected:!1});default:return e}}},exports.createPresenceActionListener=n,exports.createPubNubActionListener=function(E){return A(b(E),n(E),I(E),l(E),f(E),J(E),u(E),c(E),y(E))},exports.createSignalActionListener=I,exports.createSpace=function(e,a){return function(t){t({type:E.OBJECTS_CREATE_SPACE_BEGIN,payload:a}),e.createSpace(M({},a),function(e,r){t(e.error?{type:E.OBJECTS_CREATE_SPACE_ERROR,payload:{code:e.category,message:e.errorData,data:{id:a.id,value:a}}}:{type:E.OBJECTS_CREATE_SPACE,payload:{data:r.data}})})}},exports.createSpaceActionListener=f,exports.createSpaceListReducer=function(e){return void 0===e&&(e="all"),function(a,t){if(void 0===a&&(a={data:[],loading:!1,error:void 0}),void 0===t.payload||t.payload.label!==e)return a;switch(t.type){case E.OBJECTS_FETCH_SPACES_BEGIN:return function(E){return{data:[].concat(E.data),loading:!0,error:void 0}}(a);case E.OBJECTS_FETCH_SPACES:return r=t.payload,{data:Object.keys(r.data).map(function(E){return r.data[E].id}),loading:!1,error:void 0};case E.OBJECTS_FETCH_SPACES_ERROR:return function(E,e){return{data:[].concat(E.data),loading:!1,error:e}}(a,t.payload);default:return a}var r}},exports.createSpaceReducer=function(){return function(e,a){switch(void 0===e&&(e={byId:{},loadingById:{},errorById:{}}),a.type){case E.OBJECTS_CREATE_SPACE_BEGIN:return function(E,e){return v(E,a.payload.id)}(e);case E.OBJECTS_CREATE_SPACE:return function(E,e){return G(E,e,e.data.id)}(e,a.payload);case E.OBJECTS_CREATE_SPACE_ERROR:return function(E,e){return F(E,e,e.data.id)}(e,a.payload);case E.OBJECTS_UPDATE_SPACE_BEGIN:return function(E,e){return v(E,a.payload.id)}(e);case E.OBJECTS_UPDATE_SPACE:return function(E,e){return G(E,e,e.data.id)}(e,a.payload);case E.OBJECTS_UPDATE_SPACE_ERROR:return function(E,e){return F(E,e,e.data.id)}(e,a.payload);case E.OBJECTS_DELETE_SPACE_BEGIN:return function(E,e){return v(E,a.payload)}(e);case E.OBJECTS_DELETE_SPACE:return function(E,e){return h(E,a.payload.data.id)}(e);case E.OBJECTS_DELETE_SPACE_ERROR:return function(E,e){return F(E,e,e.data.id)}(e,a.payload);case E.OBJECTS_FETCH_SPACES_BEGIN:return e;case E.OBJECTS_FETCH_SPACES:return function(E,e){return m(E,a.payload)}(e);case E.OBJECTS_FETCH_SPACES_ERROR:return e;case E.OBJECTS_FETCH_SPACE_BY_ID_BEGIN:return function(E,e){return v(E,a.payload)}(e);case E.OBJECTS_FETCH_SPACE_BY_ID:return function(E,e){return G(E,e,e.data.id)}(e,a.payload);case E.OBJECTS_FETCH_SPACE_BY_ID_ERROR:return function(E,e){return F(E,e,e.data.id)}(e,a.payload);case E.OBJECTS_FETCH_MEMBERSHIPS:return function(E,e){var a=E;if(e.data.spaces.length>0)for(var t=0;t<e.data.spaces.length;t++){var r=e.data.spaces[t].space;void 0!==r&&(a=G(a,{data:r},r.id))}return a}(e,a.payload);default:return e}}},exports.createSubscribeStatusActionListener=c,exports.createUser=function(e,a){return function(t){t({type:E.OBJECTS_CREATE_USER_BEGIN,payload:a}),e.createUser(M({},a),function(e,r){t(e.error?{type:E.OBJECTS_CREATE_USER_ERROR,payload:{code:e.category,message:e.errorData,data:{id:a.id,value:a}}}:{type:E.OBJECTS_CREATE_USER,payload:{data:r.data}})})}},exports.createUserActionListener=l,exports.createUserListReducer=function(e){return void 0===e&&(e="all"),function(a,t){if(void 0===a&&(a={data:[],loading:!1,error:void 0}),void 0===t.payload||t.payload.label!==e)return a;switch(t.type){case E.OBJECTS_FETCH_USERS_BEGIN:return function(E){return{data:[].concat(E.data),loading:!0,error:void 0}}(a);case E.OBJECTS_FETCH_USERS:return r=t.payload,{data:Object.keys(r.data).map(function(E){return r.data[E].id}),loading:!1,error:void 0};case E.OBJECTS_FETCH_USERS_ERROR:return function(E,e){return{data:[].concat(E.data),loading:!1,error:e}}(a,t.payload);default:return a}var r}},exports.createUserReducer=function(){return function(e,a){switch(void 0===e&&(e={byId:{},loadingById:{},errorById:{}}),a.type){case E.OBJECTS_CREATE_USER_BEGIN:return function(E,e){return v(E,a.payload.id)}(e);case E.OBJECTS_CREATE_USER:return function(E,e){return G(E,e,e.data.id)}(e,a.payload);case E.OBJECTS_CREATE_USER_ERROR:return function(E,e){return F(E,e,e.data.id)}(e,a.payload);case E.OBJECTS_UPDATE_USER_BEGIN:return function(E,e){return v(E,a.payload.id)}(e);case E.OBJECTS_UPDATE_USER:return function(E,e){return G(E,e,e.data.id)}(e,a.payload);case E.OBJECTS_UPDATE_USER_ERROR:return function(E,e){return F(E,e,e.data.id)}(e,a.payload);case E.OBJECTS_DELETE_USER_BEGIN:return function(E,e){return v(E,a.payload)}(e);case E.OBJECTS_DELETE_USER:return function(E,e){return h(E,a.payload.data.id)}(e);case E.OBJECTS_DELETE_USER_ERROR:return function(E,e){return F(E,e,e.data.id)}(e,a.payload);case E.OBJECTS_FETCH_USERS_BEGIN:return e;case E.OBJECTS_FETCH_USERS:return function(E,e){return m(E,a.payload)}(e);case E.OBJECTS_FETCH_USERS_ERROR:return e;case E.OBJECTS_FETCH_USER_BY_ID_BEGIN:return function(E,e){return v(E,a.payload)}(e);case E.OBJECTS_FETCH_USER_BY_ID:return function(E,e){return G(E,e,e.data.id)}(e,a.payload);case E.OBJECTS_FETCH_USER_BY_ID_ERROR:return function(E,e){return F(E,e,e.data.id)}(e,a.payload);case E.OBJECTS_FETCH_MEMBERS:return function(E,e){var a=E;if(e.data.users.length>0)for(var t=0;t<e.data.users.length;t++){var r=e.data.users[t].user;void 0!==r&&(a=G(a,{data:r},r.id))}return a}(e,a.payload);default:return e}}},exports.decryptionError=s,exports.fetchMembers=function(e,a,t){return void 0===t&&(t={}),function(r){r({type:E.OBJECTS_FETCH_MEMBERS_BEGIN,payload:a}),e.getMembers(M({spaceId:a},t),function(e,t){r(e.error?{type:E.OBJECTS_FETCH_MEMBERS_ERROR,payload:{code:e.category,message:e.errorData,data:{id:a}}}:{type:E.OBJECTS_FETCH_MEMBERS,payload:{data:{id:a,users:t.data}}})})}},exports.fetchMemberships=function(e,a,t){return void 0===t&&(t={}),function(r){r({type:E.OBJECTS_FETCH_MEMBERSHIPS_BEGIN,payload:a}),e.getMemberships(M({userId:a},t),function(e,t){r(e.error?{type:E.OBJECTS_FETCH_MEMBERSHIPS_ERROR,payload:{code:e.category,message:e.errorData,data:{id:a}}}:{type:E.OBJECTS_FETCH_MEMBERSHIPS,payload:{data:{id:a,spaces:t.data}}})})}},exports.fetchSpaceById=function(e,a,t){return function(r){r({type:E.OBJECTS_FETCH_SPACE_BY_ID_BEGIN,payload:a}),e.getSpace(M({spaceId:a},t),function(e,t){r(e.error?{type:E.OBJECTS_FETCH_SPACE_BY_ID_ERROR,payload:{code:e.category,message:e.errorData,data:{id:a}}}:{type:E.OBJECTS_FETCH_SPACE_BY_ID,payload:{data:t.data}})})}},exports.fetchSpaces=function(e,a,t){return void 0===a&&(a={}),void 0===t&&(t="all"),function(r){r({type:E.OBJECTS_FETCH_SPACES_BEGIN,payload:{label:t}}),e.getSpaces(M({},a),function(E,e){r(E.error?U({code:E.category,message:E.errorData,data:{id:""},label:t}):N({label:t,data:e.data.reduce(function(E,e){return null===e.description&&(e.description=""),E[e.id]=e,E},{})}))})}},exports.fetchSpacesError=U,exports.fetchUserById=function(e,a,t){return function(r){r({type:E.OBJECTS_FETCH_USER_BY_ID_BEGIN,payload:a}),e.getUser(M({userId:a},t),function(e,t){r(e.error?{type:E.OBJECTS_FETCH_USER_BY_ID_ERROR,payload:{code:e.category,message:e.errorData,data:{id:a}}}:{type:E.OBJECTS_FETCH_USER_BY_ID,payload:{data:t.data}})})}},exports.fetchUsers=function(e,a,t){return void 0===a&&(a={}),void 0===t&&(t="all"),function(r){r({type:E.OBJECTS_FETCH_USERS_BEGIN,payload:{label:t}}),e.getUsers(M({},a),function(E,e){r(E.error?H({code:E.category,message:E.errorData,data:{id:""},label:t}):g({label:t,data:e.data.reduce(function(E,e){return E[e.id]=e,E},{})}))})}},exports.fetchUsersError=H,exports.joinSpaces=function(e,a){return function(t){t({type:E.OBJECTS_JOIN_SPACES_BEGIN,payload:a}),e.joinSpaces(M({},a),function(e,r){if(e.error){var n={id:a.userId,value:M({},a)};t({type:E.OBJECTS_JOIN_SPACES_ERROR,payload:{code:e.category,message:e.errorData,data:n}})}else t({type:E.OBJECTS_SPACES_JOINED,payload:{data:r.data}})})}},exports.leaveSpaces=function(e,a){return function(t){t({type:E.OBJECTS_LEAVE_SPACES_BEGIN,payload:a}),e.leaveSpaces({userId:a.userId,spaces:a.spaces.map(function(E){return E.id})},function(e,r){if(e.error){var n={id:a.userId,value:M({},a)};t({type:E.OBJECTS_LEAVE_SPACES_ERROR,payload:{code:e.category,message:e.errorData,data:n}})}else t({type:E.OBJECTS_SPACES_LEFT,payload:{data:r.data}})})}},exports.malformedResponse=R,exports.networkDown=o,exports.networkIssues=C,exports.networkUp=_,exports.reconnected=S,exports.removeMembers=function(e,a){return function(t){t({type:E.OBJECTS_REMOVE_MEMBERS_BEGIN,payload:a}),e.removeMembers({spaceId:a.spaceId,users:a.users.map(function(E){return E.id})},function(e,r){if(e.error){var n={id:a.spaceId,value:M({},a)};t({type:E.OBJECTS_REMOVE_MEMBERS_ERROR,payload:{code:e.category,message:e.errorData,data:n}})}else t({type:E.OBJECTS_MEMBERS_REMOVED,payload:{data:r.data}})})}},exports.requestMessageCountExceed=B,exports.spaceDeleted=function(e){return{type:E.OBJECTS_DELETE_SPACE,payload:e}},exports.spaceListRetrieved=N,exports.spaceUpdated=function(e){return{type:E.OBJECTS_UPDATE_SPACE,payload:e}},exports.timeoutConnection=i,exports.unknown=O,exports.updateMembers=function(e,a){return function(t){t({type:E.OBJECTS_UPDATE_MEMBERS_BEGIN,payload:a.spaceId}),e.updateMembers(M({},a),function(e,r){if(e.error){var n={id:a.spaceId,value:M({},a)};t({type:E.OBJECTS_UPDATE_MEMBERS_ERROR,payload:{code:e.category,message:e.errorData,data:n}})}else t({type:E.OBJECTS_UPDATE_MEMBERS,payload:{data:r.data}})})}},exports.updateMembership=function(e,a){return function(t){t({type:E.OBJECTS_UPDATE_MEMBERSHIP_BEGIN,payload:a.userId}),e.updateMembership(M({},a),function(e,r){if(e.error){var n={id:a.userId,value:M({},a)};t({type:E.OBJECTS_UPDATE_MEMBERSHIP_ERROR,payload:{code:e.category,message:e.errorData,data:n}})}else t({type:E.OBJECTS_UPDATE_MEMBERSHIP,payload:{data:r.data}})})}},exports.userDeleted=function(e){return{type:E.OBJECTS_DELETE_USER,payload:e}},exports.userJoin=e,exports.userLeave=a,exports.userListRetrieved=g,exports.userStateChange=r,exports.userTimeout=t,exports.userUpdated=function(e){return{type:E.OBJECTS_UPDATE_USER,payload:e}};
+"use strict";var e;!function(e){e.MESSAGE="pubnub/MESSAGE",e.JOIN="pubnub/JOIN",e.LEAVE="pubnub/LEAVE",e.TIMEOUT="pubnub/TIMEOUT",e.STATE_CHANGE="pubnub/STATE_CHANGE",e.NETWORK_UP="pubnub/NETWORK_UP",e.NETWORK_DOWN="pubnub/NETWORK_DOWN",e.NETWORK_ISSUES="pubnub/NETWORK_ISSUES",e.RECONNECTED="pubnub/RECONNECTED",e.CONNECTED="pubnub/CONNECTED",e.ACCESS_DENIED="pubnub/ACCESS_DENIED",e.MALFORMED_RESPONSE="pubnub/MALFORMED_RESPONSE",e.BAD_REQUEST="pubnub/BAD_REQUEST",e.DECRYPTION_ERROR="pubnub/DECRYPTION_ERROR",e.TIMEOUT_CONNECTION="pubnub/TIMEOUT_CONNECTION",e.REQUEST_MESSAGE_COUNT_EXCEED="pubnub/REQUEST_MESSAGE_COUNT_EXCEED",e.UNKNOWN="pubnub/UNKNOWN",e.OBJECTS_UPDATE_USER_BEGIN="pubnub/OBJECTS_UPDATE_USER_BEGIN",e.OBJECTS_UPDATE_USER="pubnub/OBJECTS_UPDATE_USER",e.OBJECTS_UPDATE_USER_ERROR="pubnub/OBJECTS_UPDATE_USER_ERROR",e.OBJECTS_DELETE_USER_BEGIN="pubnub/OBJECTS_DELETE_USER_BEGIN",e.OBJECTS_DELETE_USER="pubnub/OBJECTS_DELETE_USER",e.OBJECTS_DELETE_USER_ERROR="pubnub/OBJECTS_DELETE_USER_ERROR",e.OBJECTS_CREATE_USER_BEGIN="pubnub/OBJECTS_CREATE_USER_BEGIN",e.OBJECTS_CREATE_USER="pubnub/OBJECTS_CREATE_USER",e.OBJECTS_CREATE_USER_ERROR="pubnub/OBJECTS_CREATE_USER_ERROR",e.OBJECTS_FETCH_USERS_BEGIN="pubnub/OBJECTS_FETCH_USERS_BEGIN",e.OBJECTS_FETCH_USERS="pubnub/OBJECTS_FETCH_USERS",e.OBJECTS_FETCH_USERS_ERROR="pubnub/OBJECTS_FETCH_USERS_ERROR",e.OBJECTS_FETCH_USER_BY_ID_BEGIN="pubnub/OBJECTS_FETCH_USER_BY_ID_BEGIN",e.OBJECTS_FETCH_USER_BY_ID="pubnub/OBJECTS_FETCH_USER_BY_ID",e.OBJECTS_FETCH_USER_BY_ID_ERROR="pubnub/OBJECTS_FETCH_USER_BY_ID_ERROR",e.OBJECTS_CREATE_SPACE="pubnub/OBJECTS_CREATE_SPACE",e.OBJECTS_CREATE_SPACE_BEGIN="pubnub/OBJECTS_CREATE_SPACE_BEGIN",e.OBJECTS_CREATE_SPACE_ERROR="pubnub/OBJECTS_CREATE_SPACE_ERROR",e.OBJECTS_UPDATE_SPACE="pubnub/OBJECTS_UPDATE_SPACE",e.OBJECTS_UPDATE_SPACE_BEGIN="pubnub/OBJECTS_UPDATE_SPACE_BEGIN",e.OBJECTS_UPDATE_SPACE_ERROR="pubnub/OBJECTS_UPDATE_SPACE_ERROR",e.OBJECTS_DELETE_SPACE="pubnub/OBJECTS_DELETE_SPACE",e.OBJECTS_DELETE_SPACE_BEGIN="pubnub/OBJECTS_DELETE_SPACE_BEGIN",e.OBJECTS_DELETE_SPACE_ERROR="pubnub/OBJECTS_DELETE_SPACE_ERROR",e.OBJECTS_FETCH_SPACES="pubnub/OBJECTS_FETCH_SPACES",e.OBJECTS_FETCH_SPACES_BEGIN="pubnub/OBJECTS_FETCH_SPACES_BEGIN",e.OBJECTS_FETCH_SPACES_ERROR="pubnub/OBJECTS_FETCH_SPACES_ERROR",e.OBJECTS_FETCH_SPACE_BY_ID="pubnub/OBJECTS_FETCH_SPACE_BY_ID",e.OBJECTS_FETCH_SPACE_BY_ID_BEGIN="pubnub/OBJECTS_FETCH_SPACE_BY_ID_BEGIN",e.OBJECTS_FETCH_SPACE_BY_ID_ERROR="pubnub/OBJECTS_FETCH_SPACE_BY_ID_ERROR",e.OBJECTS_USER_ADDED_TO_SPACE="pubnub/OBJECTS_USER_ADDED_TO_SPACE",e.OBJECTS_USER_REMOVED_FROM_SPACE="pubnub/OBJECTS_USER_REMOVED_FROM_SPACE",e.OBJECTS_USER_MEMBERSHIP_UPDATED_ON_SPACE="pubnub/OBJECTS_USER_MEMBERSHIP_UPDATED_ON_SPACE",e.OBJECTS_FETCH_MEMBERS_BEGIN="pubnub/OBJECTS_FETCH_MEMBERS_BEGIN",e.OBJECTS_FETCH_MEMBERS="pubnub/OBJECTS_FETCH_MEMBERS",e.OBJECTS_FETCH_MEMBERS_ERROR="pubnub/OBJECTS_FETCH_MEMBERS_ERROR",e.OBJECTS_UPDATE_MEMBERS_BEGIN="pubnub/OBJECTS_UPDATE_MEMBERS_BEGIN",e.OBJECTS_UPDATE_MEMBERS="pubnub/OBJECTS_UPDATE_MEMBERS",e.OBJECTS_UPDATE_MEMBERS_ERROR="pubnub/OBJECTS_UPDATE_MEMBERS_ERROR",e.OBJECTS_ADD_MEMBERS_BEGIN="pubnub/OBJECTS_ADD_MEMBERS_BEGIN",e.OBJECTS_MEMBERS_ADDED="pubnub/OBJECTS_MEMBERS_ADDED",e.OBJECTS_ADD_MEMBERS_ERROR="pubnub/OBJECTS_ADD_MEMBERS_ERROR",e.OBJECTS_REMOVE_MEMBERS_BEGIN="pubnub/OBJECTS_REMOVE_MEMBERS_BEGIN",e.OBJECTS_MEMBERS_REMOVED="pubnub/OBJECTS_MEMBERS_REMOVED",e.OBJECTS_REMOVE_MEMBERS_ERROR="pubnub/OBJECTS_REMOVE_MEMBERS_ERROR",e.OBJECTS_FETCH_MEMBERSHIPS_BEGIN="pubnub/OBJECTS_FETCH_MEMBERSHIPS_BEGIN",e.OBJECTS_FETCH_MEMBERSHIPS="pubnub/OBJECTS_FETCH_MEMBERSHIPS",e.OBJECTS_FETCH_MEMBERSHIPS_ERROR="pubnub/OBJECTS_FETCH_MEMBERSHIPS_ERROR",e.OBJECTS_UPDATE_MEMBERSHIP_BEGIN="pubnub/OBJECTS_UPDATE_MEMBERSHIP_BEGIN",e.OBJECTS_UPDATE_MEMBERSHIP="pubnub/OBJECTS_UPDATE_MEMBERSHIP",e.OBJECTS_UPDATE_MEMBERSHIP_ERROR="pubnub/OBJECTS_UPDATE_MEMBERSHIP_ERROR",e.OBJECTS_JOIN_SPACES_BEGIN="pubnub/OBJECTS_JOIN_SPACES_BEGIN",e.OBJECTS_SPACES_JOINED="pubnub/OBJECTS_SPACES_JOINED",e.OBJECTS_JOIN_SPACES_ERROR="pubnub/OBJECTS_JOIN_SPACES_ERROR",e.OBJECTS_LEAVE_SPACES_BEGIN="pubnub/OBJECTS_LEAVE_SPACES_BEGIN",e.OBJECTS_SPACES_LEFT="pubnub/OBJECTS_SPACES_LEFT",e.OBJECTS_LEAVE_SPACES_ERROR="pubnub/OBJECTS_LEAVE_SPACES_ERROR",e.SIGNAL="pubnub/SIGNAL"}(e||(e={}));var E=function(E){return{type:e.JOIN,payload:E}},a=function(E){return{type:e.LEAVE,payload:E}},t=function(E){return{type:e.TIMEOUT,payload:E}},r=function(E){return{type:e.STATE_CHANGE,payload:E}},n=function(e){return{presence:function(n){switch(n.action){case"join":e(E(n));break;case"leave":e(a(n));break;case"timeout":e(t(n));break;case"state-change":e(r(n))}}}},_=function(){return{type:e.NETWORK_UP}},o=function(){return{type:e.NETWORK_DOWN}},u=function(e){return{status:function(E){switch(E.category){case"PNNetworkUpCategory":e(_());break;case"PNNetworkDownCategory":case"PNNetworkIssuesCategory":e(o());break;case"PNReconnectedCategory":case"PNConnectedCategory":e(_());break;case"PNTimeoutCategory":e(o())}}}},d=function(E){return{type:e.RECONNECTED,payload:E}},S=function(E){return{type:e.CONNECTED,payload:E}},c=function(e){return{status:function(E){switch(E.category){case"PNReconnectedCategory":e(d(E));break;case"PNConnectedCategory":e(S(E))}}}},C=function(E){return{type:e.NETWORK_ISSUES,payload:E}},T=function(E){return{type:e.ACCESS_DENIED,payload:E}},s=function(E){return{type:e.MALFORMED_RESPONSE,payload:E}},i=function(E){return{type:e.BAD_REQUEST,payload:E}},R=function(E){return{type:e.DECRYPTION_ERROR,payload:E}},p=function(E){return{type:e.TIMEOUT_CONNECTION,payload:E}},B=function(E){return{type:e.REQUEST_MESSAGE_COUNT_EXCEED,payload:E}},O=function(E){return{type:e.UNKNOWN,payload:E}},y=function(e){return{status:function(E){switch(E.category){case"PNNetworkIssuesCategory":e(C(E));break;case"PNAccessDeniedCategory":e(T(E));break;case"PNMalformedResponseCategory":e(s(E));break;case"PNBadRequestCategory":e(i(E));break;case"PNDecryptionErrorCategory":e(R(E));break;case"PNTimeoutCategory":e(p(E));break;case"PNRequestMessageCountExceedCategory":e(B(E));break;case"PNUnknownCategory":e(O(E))}}}},I=function(E){return{message:function(a){return E({type:e.MESSAGE,payload:a})}}},b=function(E){return{signal:function(a){return E({type:e.SIGNAL,payload:a})}}},f=function(E){return{user:function(a){switch(a.message.event){case"update":E(function(E){return{type:e.OBJECTS_UPDATE_USER,payload:E}}({data:a.message.data}));break;case"delete":E(function(E){return{type:e.OBJECTS_DELETE_USER,payload:E}}({data:a.message.data}))}}}},l=function(E){return{space:function(a){switch(a.message.event){case"update":E(function(E){return{type:e.OBJECTS_UPDATE_SPACE,payload:E}}({data:a.message.data}));break;case"delete":E(function(E){return{type:e.OBJECTS_DELETE_SPACE,payload:E}}({data:a.message.data}))}}}},J=function(E){return{membership:function(a){var t={id:a.message.data.userId+"_"+a.message.data.spaceId,data:a.message.data};switch(a.message.event){case"create":E({type:e.OBJECTS_USER_ADDED_TO_SPACE,payload:t});break;case"update":E({type:e.OBJECTS_USER_MEMBERSHIP_UPDATED_ON_SPACE,payload:t});break;case"delete":E({type:e.OBJECTS_USER_REMOVED_FROM_SPACE,payload:t})}}}},A=function(){for(var e=arguments.length,E=new Array(e),a=0;a<e;a++)E[a]=arguments[a];return Object.assign.apply(Object,[{}].concat(M(E)))},M=function(e){var E=[],a={};return e.forEach(function(e){var E=Object.keys(e)[0];a.hasOwnProperty(E)||(a[E]=[]),a[E].push(e)}),Object.entries(a).forEach(function(e){var a=e[0],t=e[1];1===t.length?E.push(t[0]):t.length>1&&E.push(P(a,t))}),E},P=function(e,E){var a;return(a={})[e]=function(a){E.forEach(function(E){console.log("any event",JSON.stringify(a)),E[e](a)})},a};function D(){return(D=Object.assign||function(e){for(var E=1;E<arguments.length;E++){var a=arguments[E];for(var t in a)Object.prototype.hasOwnProperty.call(a,t)&&(e[t]=a[t])}return e}).apply(this,arguments)}var N=function(E){return{type:e.OBJECTS_FETCH_SPACES,payload:E}},U=function(E){return{type:e.OBJECTS_FETCH_SPACES_ERROR,payload:E}},g=function(E){return{type:e.OBJECTS_FETCH_USERS,payload:E}},H=function(E){return{type:e.OBJECTS_FETCH_USERS_ERROR,payload:E}},v=function(e,E){var a=L(e);return a.loadingById[E]=void 0!==a.loadingById[E]?a.loadingById[E]+1:1,delete a.errorById[E],a},F=function(e,E,a){var t=L(e);return t.loadingById[a]=t.loadingById[a]>0?t.loadingById[a]-1:0,t.errorById[a]=E,t},G=function(e,E,a){var t=L(e);return t.loadingById[a]=t.loadingById[a]>0?t.loadingById[a]-1:0,"[object Array]"===Object.prototype.toString.call(E.data)?t.byId[a]=k(E.data):"object"==typeof E.data&&(t.byId[a]=x(E.data)),t},h=function(e,E){var a=L(e);return a.byId=D({},a.byId,{},x(E.data)),a},m=function(e,E){var a=L(e);return a.loadingById[E]=a.loadingById[E]>0?a.loadingById[E]-1:0,delete a.byId[E],a},L=function(e){var E={byId:{},loadingById:D({},e.loadingById),errorById:{}};return Object.keys(e.byId).forEach(function(a){"[object Array]"===Object.prototype.toString.call(e.byId[a])?E.byId[a]=k(e.byId[a]):"object"==typeof e.byId[a]&&(E.byId[a]=x(e.byId[a]))}),Object.keys(e.errorById).forEach(function(a){E.errorById[a]=x(e.errorById[a])}),E},x=function e(E){var a=D({},E);for(var t in E)E.hasOwnProperty(t)&&("[object Array]"===Object.prototype.toString.call(E[t])?a[t]=k(E[t]):"object"==typeof E[t]&&(a[t]=e(E[t])));return a},k=function e(E){for(var a=[].concat(E),t=0;t<a.length;t++){var r=a[t];"[object Array]"===Object.prototype.toString.call(r)?a[t]=e(r):"object"==typeof a[t]&&(a[t]=x(r))}return a};exports.accessDenied=T,exports.addMembers=function(E,a){return function(t){t({type:e.OBJECTS_ADD_MEMBERS_BEGIN,payload:a}),E.addMembers(D({},a),function(E,r){if(E.error){var n={id:a.spaceId,value:D({},a)};t({type:e.OBJECTS_ADD_MEMBERS_ERROR,payload:{code:E.category,message:E.errorData,data:n}})}else t({type:e.OBJECTS_MEMBERS_ADDED,payload:{data:r.data}})})}},exports.badRequest=i,exports.combineListeners=A,exports.connected=S,exports.createErrorStatusActionListener=y,exports.createMembersReducer=function(){return function(E,a){switch(void 0===E&&(E={byId:{},loadingById:{},errorById:{}}),a.type){case e.OBJECTS_USER_ADDED_TO_SPACE:return function(e,E){var a=D({},e);Object.keys(a.byId).forEach(function(e){a.byId[e]=[].concat(a.byId[e])});var t=a.byId[E.data.userId];return void 0===t?a.byId[E.data.userId]=[{id:E.data.spaceId}]:0===t.filter(function(e){return e.id===E.data.spaceId}).length&&t.push({id:E.data.spaceId}),a}(E,a.payload);case e.OBJECTS_USER_REMOVED_FROM_SPACE:return function(e,E){var a=D({},e);return Object.keys(a.byId).forEach(function(E){a.byId[E]=[].concat(e.byId[E])}),void 0!==a.byId[E.data.userId]&&(a.byId[E.data.userId]=a.byId[E.data.userId].filter(function(e){return e.id!==E.data.spaceId})),a}(E,a.payload);case e.OBJECTS_USER_MEMBERSHIP_UPDATED_ON_SPACE:return function(e,E){var a=D({},e);return Object.keys(a.byId).forEach(function(E){a.byId[E]=[].concat(e.byId[E])}),void 0!==a.byId[E.data.userId]&&a.byId[E.data.userId].filter(function(e){return e.id===E.data.spaceId}),a}(E,a.payload);case e.OBJECTS_FETCH_MEMBERS_BEGIN:return function(e,E){var a=D({},e);return Object.keys(a.byId).forEach(function(E){a.byId[E]=[].concat(e.byId[E])}),a.loadingById[E]=void 0!==a.loadingById[E]?a.loadingById[E]+1:1,delete a.errorById[E],a}(E,a.payload);case e.OBJECTS_FETCH_MEMBERS:return function(e,E){var a=D({},e);Object.keys(a.byId).forEach(function(E){a.byId[E]=[].concat(e.byId[E])});var t=E.data.id;return a.loadingById[t]=a.loadingById[t]>0?a.loadingById[t]-1:0,a.byId[t]=[].concat(E.data.users),a}(E,a.payload);case e.OBJECTS_FETCH_MEMBERS_ERROR:return function(e,E){var a=D({},e);if(Object.keys(a.byId).forEach(function(E){a.byId[E]=[].concat(e.byId[E])}),E.data.id){var t=E.data.id;a.loadingById[t]=a.loadingById[t]>0?a.loadingById[t]-1:0,a.errorById[t]=E}return a}(E,a.payload);case e.OBJECTS_UPDATE_MEMBERS_BEGIN:return function(e,E){return v(e,a.payload)}(E);case e.OBJECTS_UPDATE_MEMBERS:return function(e,E){return G(e,{data:E.data.users},E.data.spaceId)}(E,a.payload);case e.OBJECTS_UPDATE_MEMBERS_ERROR:return function(e,E){return F(e,E,E.data.id)}(E,a.payload);case e.OBJECTS_ADD_MEMBERS_BEGIN:return function(e,E){return v(e,a.payload)}(E);case e.OBJECTS_MEMBERS_ADDED:return function(e,E){return G(e,{data:E.data.users},E.data.spaceId)}(E,a.payload);case e.OBJECTS_ADD_MEMBERS_ERROR:return function(e,E){return F(e,E,E.data.id)}(E,a.payload);case e.OBJECTS_REMOVE_MEMBERS_BEGIN:return function(e,E){return v(e,a.payload)}(E);case e.OBJECTS_MEMBERS_REMOVED:return function(e,E){return G(e,{data:E.data.users},E.data.spaceId)}(E,a.payload);case e.OBJECTS_REMOVE_MEMBERS_ERROR:return function(e,E){return F(e,E,E.data.id)}(E,a.payload);default:return E}}},exports.createMembershipActionListener=J,exports.createMembershipReducer=function(){return function(E,a){switch(void 0===E&&(E={byId:{},loadingById:{},errorById:{}}),a.type){case e.OBJECTS_USER_ADDED_TO_SPACE:return function(e,E){var a=D({},e);console.log("user added to space",JSON.stringify(E)),Object.keys(a.byId).forEach(function(e){a.byId[e]=[].concat(a.byId[e])});var t=a.byId[E.data.userId];return void 0===t?a.byId[E.data.userId]=[{id:E.data.spaceId}]:0===t.filter(function(e){return e.id===E.data.spaceId}).length&&t.push({id:E.data.spaceId}),a}(E,a.payload);case e.OBJECTS_USER_REMOVED_FROM_SPACE:return function(e,E){var a=D({},e);return Object.keys(a.byId).forEach(function(E){a.byId[E]=[].concat(e.byId[E])}),void 0!==a.byId[E.data.userId]&&(a.byId[E.data.userId]=a.byId[E.data.userId].filter(function(e){return e.id!==E.data.spaceId})),a}(E,a.payload);case e.OBJECTS_USER_MEMBERSHIP_UPDATED_ON_SPACE:return function(e,E){var a=D({},e);return Object.keys(a.byId).forEach(function(E){a.byId[E]=[].concat(e.byId[E])}),void 0!==a.byId[E.data.userId]&&a.byId[E.data.userId].filter(function(e){return e.id===E.data.spaceId}),a}(E,a.payload);case e.OBJECTS_FETCH_MEMBERSHIPS_BEGIN:return function(e,E){return v(e,a.payload)}(E);case e.OBJECTS_FETCH_MEMBERSHIPS:return function(e,E){return G(e,{data:E.data.spaces},E.data.id)}(E,a.payload);case e.OBJECTS_FETCH_MEMBERSHIPS_ERROR:return function(e,E){return F(e,{code:E.code,message:E.message,data:{id:E.data.id}},E.data.id)}(E,a.payload);case e.OBJECTS_UPDATE_MEMBERSHIP_BEGIN:return function(e,E){return v(e,a.payload)}(E);case e.OBJECTS_UPDATE_MEMBERSHIP:return function(e,E){return G(e,{data:E.data.spaces},E.data.userId)}(E,a.payload);case e.OBJECTS_UPDATE_MEMBERSHIP_ERROR:return function(e,E){return F(e,E,E.data.id)}(E,a.payload);case e.OBJECTS_JOIN_SPACES_BEGIN:return function(e,E){return v(e,a.payload)}(E);case e.OBJECTS_SPACES_JOINED:return function(e,E){return G(e,{data:E.data.spaces},E.data.userId)}(E,a.payload);case e.OBJECTS_JOIN_SPACES_ERROR:return function(e,E){return F(e,E,E.data.id)}(E,a.payload);case e.OBJECTS_LEAVE_SPACES_BEGIN:return function(e,E){return v(e,a.payload)}(E);case e.OBJECTS_SPACES_LEFT:return function(e,E){return G(e,{data:E.data.spaces},E.data.userId)}(E,a.payload);case e.OBJECTS_LEAVE_SPACES_ERROR:return function(e,E){return F(e,E,E.data.id)}(E,a.payload);default:return E}}},exports.createMessageActionListener=I,exports.createNetworkStatusActionListener=u,exports.createNetworkStatusReducer=function(E){var a;if("boolean"==typeof E)a={isConnected:E};else{if("function"!=typeof E)throw new Error("The initializer parameter must be a boolean value (true or false) or function");if("boolean"!=typeof(a={isConnected:E()}).isConnected)throw new Error("The initializer function must return a boolean value (true or false)")}return function(E,t){switch(void 0===E&&(E=a),t.type){case e.NETWORK_UP:return D({},E,{isConnected:!0});case e.NETWORK_DOWN:return D({},E,{isConnected:!1});default:return E}}},exports.createPresenceActionListener=n,exports.createPubNubActionListener=function(e){return A(I(e),n(e),b(e),f(e),l(e),J(e),u(e),c(e),y(e))},exports.createSignalActionListener=b,exports.createSpace=function(E,a){return function(t){t({type:e.OBJECTS_CREATE_SPACE_BEGIN,payload:a}),E.createSpace(D({},a),function(E,r){t(E.error?{type:e.OBJECTS_CREATE_SPACE_ERROR,payload:{code:E.category,message:E.errorData,data:{id:a.id,value:a}}}:{type:e.OBJECTS_CREATE_SPACE,payload:{data:r.data}})})}},exports.createSpaceActionListener=l,exports.createSpaceListReducer=function(E){return void 0===E&&(E="all"),function(a,t){if(void 0===a&&(a={data:[],loading:!1,error:void 0}),void 0===t.payload||t.payload.label!==E)return a;switch(t.type){case e.OBJECTS_FETCH_SPACES_BEGIN:return function(e){return{data:[].concat(e.data),loading:!0,error:void 0}}(a);case e.OBJECTS_FETCH_SPACES:return r=t.payload,{data:Object.keys(r.data).map(function(e){return r.data[e].id}),loading:!1,error:void 0};case e.OBJECTS_FETCH_SPACES_ERROR:return function(e,E){return{data:[].concat(e.data),loading:!1,error:E}}(a,t.payload);default:return a}var r}},exports.createSpaceReducer=function(){return function(E,a){switch(void 0===E&&(E={byId:{},loadingById:{},errorById:{}}),a.type){case e.OBJECTS_CREATE_SPACE_BEGIN:return function(e,E){return v(e,a.payload.id)}(E);case e.OBJECTS_CREATE_SPACE:return function(e,E){return G(e,E,E.data.id)}(E,a.payload);case e.OBJECTS_CREATE_SPACE_ERROR:return function(e,E){return F(e,E,E.data.id)}(E,a.payload);case e.OBJECTS_UPDATE_SPACE_BEGIN:return function(e,E){return v(e,a.payload.id)}(E);case e.OBJECTS_UPDATE_SPACE:return function(e,E){return G(e,E,E.data.id)}(E,a.payload);case e.OBJECTS_UPDATE_SPACE_ERROR:return function(e,E){return F(e,E,E.data.id)}(E,a.payload);case e.OBJECTS_DELETE_SPACE_BEGIN:return function(e,E){return v(e,a.payload)}(E);case e.OBJECTS_DELETE_SPACE:return function(e,E){return m(e,a.payload.data.id)}(E);case e.OBJECTS_DELETE_SPACE_ERROR:return function(e,E){return F(e,E,E.data.id)}(E,a.payload);case e.OBJECTS_FETCH_SPACES_BEGIN:return E;case e.OBJECTS_FETCH_SPACES:return function(e,E){return h(e,a.payload)}(E);case e.OBJECTS_FETCH_SPACES_ERROR:return E;case e.OBJECTS_FETCH_SPACE_BY_ID_BEGIN:return function(e,E){return v(e,a.payload)}(E);case e.OBJECTS_FETCH_SPACE_BY_ID:return function(e,E){return G(e,E,E.data.id)}(E,a.payload);case e.OBJECTS_FETCH_SPACE_BY_ID_ERROR:return function(e,E){return F(e,E,E.data.id)}(E,a.payload);case e.OBJECTS_FETCH_MEMBERSHIPS:return function(e,E){var a=e;if(E.data.spaces.length>0)for(var t=0;t<E.data.spaces.length;t++){var r=E.data.spaces[t].space;void 0!==r&&(a=G(a,{data:r},r.id))}return a}(E,a.payload);default:return E}}},exports.createSubscribeStatusActionListener=c,exports.createUser=function(E,a){return function(t){t({type:e.OBJECTS_CREATE_USER_BEGIN,payload:a}),E.createUser(D({},a),function(E,r){t(E.error?{type:e.OBJECTS_CREATE_USER_ERROR,payload:{code:E.category,message:E.errorData,data:{id:a.id,value:a}}}:{type:e.OBJECTS_CREATE_USER,payload:{data:r.data}})})}},exports.createUserActionListener=f,exports.createUserListReducer=function(E){return void 0===E&&(E="all"),function(a,t){if(void 0===a&&(a={data:[],loading:!1,error:void 0}),void 0===t.payload||t.payload.label!==E)return a;switch(t.type){case e.OBJECTS_FETCH_USERS_BEGIN:return function(e){return{data:[].concat(e.data),loading:!0,error:void 0}}(a);case e.OBJECTS_FETCH_USERS:return r=t.payload,{data:Object.keys(r.data).map(function(e){return r.data[e].id}),loading:!1,error:void 0};case e.OBJECTS_FETCH_USERS_ERROR:return function(e,E){return{data:[].concat(e.data),loading:!1,error:E}}(a,t.payload);default:return a}var r}},exports.createUserReducer=function(){return function(E,a){switch(void 0===E&&(E={byId:{},loadingById:{},errorById:{}}),a.type){case e.OBJECTS_CREATE_USER_BEGIN:return function(e,E){return v(e,a.payload.id)}(E);case e.OBJECTS_CREATE_USER:return function(e,E){return G(e,E,E.data.id)}(E,a.payload);case e.OBJECTS_CREATE_USER_ERROR:return function(e,E){return F(e,E,E.data.id)}(E,a.payload);case e.OBJECTS_UPDATE_USER_BEGIN:return function(e,E){return v(e,a.payload.id)}(E);case e.OBJECTS_UPDATE_USER:return function(e,E){return G(e,E,E.data.id)}(E,a.payload);case e.OBJECTS_UPDATE_USER_ERROR:return function(e,E){return F(e,E,E.data.id)}(E,a.payload);case e.OBJECTS_DELETE_USER_BEGIN:return function(e,E){return v(e,a.payload)}(E);case e.OBJECTS_DELETE_USER:return function(e,E){return m(e,a.payload.data.id)}(E);case e.OBJECTS_DELETE_USER_ERROR:return function(e,E){return F(e,E,E.data.id)}(E,a.payload);case e.OBJECTS_FETCH_USERS_BEGIN:return E;case e.OBJECTS_FETCH_USERS:return function(e,E){return h(e,a.payload)}(E);case e.OBJECTS_FETCH_USERS_ERROR:return E;case e.OBJECTS_FETCH_USER_BY_ID_BEGIN:return function(e,E){return v(e,a.payload)}(E);case e.OBJECTS_FETCH_USER_BY_ID:return function(e,E){return G(e,E,E.data.id)}(E,a.payload);case e.OBJECTS_FETCH_USER_BY_ID_ERROR:return function(e,E){return F(e,E,E.data.id)}(E,a.payload);case e.OBJECTS_FETCH_MEMBERS:return function(e,E){var a=e;if(E.data.users.length>0)for(var t=0;t<E.data.users.length;t++){var r=E.data.users[t].user;void 0!==r&&(a=G(a,{data:r},r.id))}return a}(E,a.payload);default:return E}}},exports.decryptionError=R,exports.fetchMembers=function(E,a,t){return void 0===t&&(t={}),function(r){r({type:e.OBJECTS_FETCH_MEMBERS_BEGIN,payload:a}),E.getMembers(D({spaceId:a},t),function(E,t){r(E.error?{type:e.OBJECTS_FETCH_MEMBERS_ERROR,payload:{code:E.category,message:E.errorData,data:{id:a}}}:{type:e.OBJECTS_FETCH_MEMBERS,payload:{data:{id:a,users:t.data}}})})}},exports.fetchMemberships=function(E,a,t){return void 0===t&&(t={}),function(r){r({type:e.OBJECTS_FETCH_MEMBERSHIPS_BEGIN,payload:a}),E.getMemberships(D({userId:a},t),function(E,t){r(E.error?{type:e.OBJECTS_FETCH_MEMBERSHIPS_ERROR,payload:{code:E.category,message:E.errorData,data:{id:a}}}:{type:e.OBJECTS_FETCH_MEMBERSHIPS,payload:{data:{id:a,spaces:t.data}}})})}},exports.fetchSpaceById=function(E,a,t){return function(r){r({type:e.OBJECTS_FETCH_SPACE_BY_ID_BEGIN,payload:a}),E.getSpace(D({spaceId:a},t),function(E,t){r(E.error?{type:e.OBJECTS_FETCH_SPACE_BY_ID_ERROR,payload:{code:E.category,message:E.errorData,data:{id:a}}}:{type:e.OBJECTS_FETCH_SPACE_BY_ID,payload:{data:t.data}})})}},exports.fetchSpaces=function(E,a,t){return void 0===a&&(a={}),void 0===t&&(t="all"),function(r){r({type:e.OBJECTS_FETCH_SPACES_BEGIN,payload:{label:t}}),E.getSpaces(D({},a),function(e,E){r(e.error?U({code:e.category,message:e.errorData,data:{id:""},label:t}):N({label:t,data:E.data.reduce(function(e,E){return null===E.description&&(E.description=""),e[E.id]=E,e},{})}))})}},exports.fetchSpacesError=U,exports.fetchUserById=function(E,a,t){return function(r){r({type:e.OBJECTS_FETCH_USER_BY_ID_BEGIN,payload:a}),E.getUser(D({userId:a},t),function(E,t){r(E.error?{type:e.OBJECTS_FETCH_USER_BY_ID_ERROR,payload:{code:E.category,message:E.errorData,data:{id:a}}}:{type:e.OBJECTS_FETCH_USER_BY_ID,payload:{data:t.data}})})}},exports.fetchUsers=function(E,a,t){return void 0===a&&(a={}),void 0===t&&(t="all"),function(r){r({type:e.OBJECTS_FETCH_USERS_BEGIN,payload:{label:t}}),E.getUsers(D({},a),function(e,E){r(e.error?H({code:e.category,message:e.errorData,data:{id:""},label:t}):g({label:t,data:E.data.reduce(function(e,E){return e[E.id]=E,e},{})}))})}},exports.fetchUsersError=H,exports.joinSpaces=function(E,a){return function(t){t({type:e.OBJECTS_JOIN_SPACES_BEGIN,payload:a}),E.joinSpaces(D({},a),function(E,r){if(E.error){var n={id:a.userId,value:D({},a)};t({type:e.OBJECTS_JOIN_SPACES_ERROR,payload:{code:E.category,message:E.errorData,data:n}})}else t({type:e.OBJECTS_SPACES_JOINED,payload:{data:r.data}})})}},exports.leaveSpaces=function(E,a){return function(t){t({type:e.OBJECTS_LEAVE_SPACES_BEGIN,payload:a}),E.leaveSpaces({userId:a.userId,spaces:a.spaces.map(function(e){return e.id})},function(E,r){if(E.error){var n={id:a.userId,value:D({},a)};t({type:e.OBJECTS_LEAVE_SPACES_ERROR,payload:{code:E.category,message:E.errorData,data:n}})}else t({type:e.OBJECTS_SPACES_LEFT,payload:{data:r.data}})})}},exports.malformedResponse=s,exports.networkDown=o,exports.networkIssues=C,exports.networkUp=_,exports.reconnected=d,exports.removeMembers=function(E,a){return function(t){t({type:e.OBJECTS_REMOVE_MEMBERS_BEGIN,payload:a}),E.removeMembers({spaceId:a.spaceId,users:a.users.map(function(e){return e.id})},function(E,r){if(E.error){var n={id:a.spaceId,value:D({},a)};t({type:e.OBJECTS_REMOVE_MEMBERS_ERROR,payload:{code:E.category,message:E.errorData,data:n}})}else t({type:e.OBJECTS_MEMBERS_REMOVED,payload:{data:r.data}})})}},exports.requestMessageCountExceed=B,exports.spaceDeleted=function(E){return{type:e.OBJECTS_DELETE_SPACE,payload:E}},exports.spaceListRetrieved=N,exports.spaceUpdated=function(E){return{type:e.OBJECTS_UPDATE_SPACE,payload:E}},exports.timeoutConnection=p,exports.unknown=O,exports.updateMembers=function(E,a){return function(t){t({type:e.OBJECTS_UPDATE_MEMBERS_BEGIN,payload:a.spaceId}),E.updateMembers(D({},a),function(E,r){if(E.error){var n={id:a.spaceId,value:D({},a)};t({type:e.OBJECTS_UPDATE_MEMBERS_ERROR,payload:{code:E.category,message:E.errorData,data:n}})}else t({type:e.OBJECTS_UPDATE_MEMBERS,payload:{data:r.data}})})}},exports.updateMembership=function(E,a){return function(t){t({type:e.OBJECTS_UPDATE_MEMBERSHIP_BEGIN,payload:a.userId}),E.updateMembership(D({},a),function(E,r){if(E.error){var n={id:a.userId,value:D({},a)};t({type:e.OBJECTS_UPDATE_MEMBERSHIP_ERROR,payload:{code:E.category,message:E.errorData,data:n}})}else t({type:e.OBJECTS_UPDATE_MEMBERSHIP,payload:{data:r.data}})})}},exports.userDeleted=function(E){return{type:e.OBJECTS_DELETE_USER,payload:E}},exports.userJoin=E,exports.userLeave=a,exports.userListRetrieved=g,exports.userStateChange=r,exports.userTimeout=t,exports.userUpdated=function(E){return{type:e.OBJECTS_UPDATE_USER,payload:E}};
 //# sourceMappingURL=pubnub-redux.cjs.production.min.js.map

dist/pubnub-redux.esm.js

@@ -1926,3 +1926,223 @@ var actionType;
 
-export { accessDenied, addMembers, badRequest, combineListeners, connected, createErrorStatusActionListener, createMembershipActionListener, createMembershipReducer, createMessageActionListener, createNetworkStatusActionListener, createNetworkStatusReducer, createPresenceActionListener, createPubNubActionListener, createSignalActionListener, createSpace, createSpaceActionListener, createSpaceListReducer, createSpaceReducer, createSubscribeStatusActionListener, createUser, createUserActionListener, createUserListReducer, createUserReducer, decryptionError, fetchMembers, fetchMemberships, fetchSpaceById, fetchSpaces, fetchSpacesError, fetchUserById, fetchUsers, fetchUsersError, joinSpaces, leaveSpaces, malformedResponse, networkDown, networkIssues, networkUp, reconnected, removeMembers, requestMessageCountExceed, spaceDeleted$1 as spaceDeleted, spaceListRetrieved, spaceUpdated$1 as spaceUpdated, timeoutConnection, unknown, updateMembers, updateMembership, userDeleted$1 as userDeleted, userJoin, userLeave, userListRetrieved, userStateChange, userTimeout, userUpdated$1 as userUpdated };
+var createInitialState$5 = function createInitialState() {
+  return {
+    byId: {},
+    loadingById: {},
+    errorById: {}
+  };
+};
+
+var userAddedToSpace$2 = function userAddedToSpace(state, payload) {
+  var newState = _extends({}, state);
+
+  Object.keys(newState.byId).forEach(function (key) {
+    newState.byId[key] = [].concat(newState.byId[key]);
+  });
+  var currentValue = newState.byId[payload.data.userId];
+
+  if (currentValue === undefined) {
+    newState.byId[payload.data.userId] = [{
+      id: payload.data.spaceId
+    }];
+  } else if (currentValue.filter(function (item) {
+    return item.id === payload.data.spaceId;
+  }).length === 0) {
+    currentValue.push({
+      id: payload.data.spaceId
+    });
+  }
+
+  return newState;
+};
+
+var userRemovedFromSpace$2 = function userRemovedFromSpace(state, payload) {
+  var newState = _extends({}, state);
+
+  Object.keys(newState.byId).forEach(function (key) {
+    newState.byId[key] = [].concat(state.byId[key]);
+  });
+  var currentValue = newState.byId[payload.data.userId];
+
+  if (currentValue !== undefined) {
+    newState.byId[payload.data.userId] = newState.byId[payload.data.userId].filter(function (item) {
+      return item.id !== payload.data.spaceId;
+    });
+  }
+
+  return newState;
+};
+
+var userMembersUpdatedOnSpace = function userMembersUpdatedOnSpace(state, payload) {
+  var newState = _extends({}, state);
+
+  Object.keys(newState.byId).forEach(function (key) {
+    newState.byId[key] = [].concat(state.byId[key]);
+  });
+  var currentValue = newState.byId[payload.data.userId];
+
+  if (currentValue !== undefined) {
+    var existing = newState.byId[payload.data.userId].filter(function (item) {
+      return item.id === payload.data.spaceId;
+    });
+
+    if (existing.length > 0) ;
+  }
+
+  return newState;
+};
+
+var beginFetchMembers = function beginFetchMembers(state, payload) {
+  var newState = _extends({}, state);
+
+  Object.keys(newState.byId).forEach(function (key) {
+    newState.byId[key] = [].concat(state.byId[key]);
+  }); // increment loading count or set to 1
+
+  newState.loadingById[payload] = newState.loadingById[payload] !== undefined ? newState.loadingById[payload] + 1 : 1; // clear error
+
+  delete newState.errorById[payload];
+  return newState;
+};
+
+var fetchMembers$2 = function fetchMembers(state, payload) {
+  var newState = _extends({}, state);
+
+  Object.keys(newState.byId).forEach(function (key) {
+    newState.byId[key] = [].concat(state.byId[key]);
+  });
+  var id = payload.data.id; // decrement loading count or set to 0
+
+  newState.loadingById[id] = newState.loadingById[id] > 0 ? newState.loadingById[id] - 1 : 0; // set response payload
+
+  newState.byId[id] = [].concat(payload.data.users);
+  return newState;
+};
+
+var fetchMembersError$1 = function fetchMembersError(state, payload) {
+  var newState = _extends({}, state);
+
+  Object.keys(newState.byId).forEach(function (key) {
+    newState.byId[key] = [].concat(state.byId[key]);
+  });
+
+  if (payload.data.id) {
+    var id = payload.data.id; // decrement loading count or set to 0
+
+    newState.loadingById[id] = newState.loadingById[id] > 0 ? newState.loadingById[id] - 1 : 0; // set error payload
+
+    newState.errorById[id] = payload;
+  }
+
+  return newState;
+};
+
+var beginUpdateMembers = function beginUpdateMembers(state, payload) {
+  return beginObjectById(state, payload);
+};
+
+var updateMembers$1 = function updateMembers(state, payload) {
+  return successObjectById(state, {
+    data: payload.data.users
+  }, payload.data.spaceId);
+};
+
+var updateMembersError$1 = function updateMembersError(state, payload) {
+  return errorObjectById(state, payload, payload.data.id);
+};
+
+var beginAddMembers = function beginAddMembers(state, payload) {
+  return beginObjectById(state, payload);
+};
+
+var addMembers$1 = function addMembers(state, payload) {
+  return successObjectById(state, {
+    data: payload.data.users
+  }, payload.data.spaceId);
+};
+
+var addMembersError$1 = function addMembersError(state, payload) {
+  return errorObjectById(state, payload, payload.data.id);
+};
+
+var beginRemoveMembers = function beginRemoveMembers(state, payload) {
+  return beginObjectById(state, payload);
+};
+
+var removeMembers$1 = function removeMembers(state, payload) {
+  return successObjectById(state, {
+    data: payload.data.users
+  }, payload.data.spaceId);
+};
+
+var removeMembersError$1 = function removeMembersError(state, payload) {
+  return errorObjectById(state, payload, payload.data.id);
+};
+
+var createMembersReducer = function createMembersReducer() {
+  return function (state, action) {
+    if (state === void 0) {
+      state = createInitialState$5();
+    }
+
+    switch (action.type) {
+      case actionType.OBJECTS_USER_ADDED_TO_SPACE:
+        return userAddedToSpace$2(state, action.payload);
+
+      case actionType.OBJECTS_USER_REMOVED_FROM_SPACE:
+        return userRemovedFromSpace$2(state, action.payload);
+
+      case actionType.OBJECTS_USER_MEMBERSHIP_UPDATED_ON_SPACE:
+        return userMembersUpdatedOnSpace(state, action.payload);
+
+      case actionType.OBJECTS_FETCH_MEMBERS_BEGIN:
+        return beginFetchMembers(state, action.payload);
+
+      case actionType.OBJECTS_FETCH_MEMBERS:
+        return fetchMembers$2(state, action.payload);
+
+      case actionType.OBJECTS_FETCH_MEMBERS_ERROR:
+        return fetchMembersError$1(state, action.payload);
+
+      case actionType.OBJECTS_UPDATE_MEMBERS_BEGIN:
+        return beginUpdateMembers(state, action.payload);
+
+      case actionType.OBJECTS_UPDATE_MEMBERS:
+        return updateMembers$1(state, action.payload);
+
+      case actionType.OBJECTS_UPDATE_MEMBERS_ERROR:
+        return updateMembersError$1(state, action.payload);
+
+      case actionType.OBJECTS_ADD_MEMBERS_BEGIN:
+        return beginAddMembers(state, action.payload);
+
+      case actionType.OBJECTS_MEMBERS_ADDED:
+        return addMembers$1(state, action.payload);
+
+      case actionType.OBJECTS_ADD_MEMBERS_ERROR:
+        return addMembersError$1(state, action.payload);
+
+      case actionType.OBJECTS_REMOVE_MEMBERS_BEGIN:
+        return beginRemoveMembers(state, action.payload);
+
+      case actionType.OBJECTS_MEMBERS_REMOVED:
+        return removeMembers$1(state, action.payload);
+
+      case actionType.OBJECTS_REMOVE_MEMBERS_ERROR:
+        return removeMembersError$1(state, action.payload);
+
+      default:
+        return state;
+    }
+  };
+}; //   | UpdateMembersBeginAction<T>
+//   | MembersUpdatedAction<T>
+//   | UpdateMembersErrorAction<T>
+//   | JoinSpacesBeginAction<T>
+//   | SpacesJoinedAction<T>
+//   | JoinSpacesErrorAction<T>
+//   | LeaveSpacesBeginAction<T>
+//   | SpacesLeftAction<T>
+//   | LeaveSpacesErrorAction<T>;
+
+export { accessDenied, addMembers, badRequest, combineListeners, connected, createErrorStatusActionListener, createMembersReducer, createMembershipActionListener, createMembershipReducer, createMessageActionListener, createNetworkStatusActionListener, createNetworkStatusReducer, createPresenceActionListener, createPubNubActionListener, createSignalActionListener, createSpace, createSpaceActionListener, createSpaceListReducer, createSpaceReducer, createSubscribeStatusActionListener, createUser, createUserActionListener, createUserListReducer, createUserReducer, decryptionError, fetchMembers, fetchMemberships, fetchSpaceById, fetchSpaces, fetchSpacesError, fetchUserById, fetchUsers, fetchUsersError, joinSpaces, leaveSpaces, malformedResponse, networkDown, networkIssues, networkUp, reconnected, removeMembers, requestMessageCountExceed, spaceDeleted$1 as spaceDeleted, spaceListRetrieved, spaceUpdated$1 as spaceUpdated, timeoutConnection, unknown, updateMembers, updateMembership, userDeleted$1 as userDeleted, userJoin, userLeave, userListRetrieved, userStateChange, userTimeout, userUpdated$1 as userUpdated };
 //# sourceMappingURL=pubnub-redux.esm.js.map

package.json

 {
   "name": "pubnub-redux",
-  "version": "0.1.12-alpha",
+  "version": "0.1.14-alpha",
   "main": "dist/index.js",
@@ -5,0 +5,0 @@ "module": "dist/reduxsdk.esm.js",

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

603310

increased by10.57%

Lines of code

5225

increased by7.05%

No dependency changes