Socket
Socket
Sign inDemoInstall

pubnub-redux

Package Overview
Dependencies
Maintainers
1
Versions
42
Alerts
File Explorer

Advanced tools

License
Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

pubnub-redux - npm Package Compare versions

Comparing version 0.1.10-alpha to 0.1.11-alpha

15

dist/pubnub-redux.cjs.development.js

@@ -684,3 +684,8 @@ 'use strict';

dispatch(leaveSpacesBegin(membership));
pubnub.leaveSpaces(_extends({}, membership), function (status, response) {
pubnub.leaveSpaces({
userId: membership.userId,
spaces: membership.spaces.map(function (space) {
return space.id;
})
}, function (status, response) {
if (status.error) {

@@ -858,3 +863,8 @@ var errorData = {

dispatch(removeMembersBegin(members));
pubnub.removeMembers(_extends({}, members), function (status, response) {
pubnub.removeMembers({
spaceId: members.spaceId,
users: members.users.map(function (user) {
return user.id;
})
}, function (status, response) {
if (status.error) {

@@ -1742,2 +1752,3 @@ var errorData = {

console.log('user added to space', JSON.stringify(payload));
Object.keys(newState.byId).forEach(function (key) {

@@ -1744,0 +1755,0 @@ newState.byId[key] = [].concat(newState.byId[key]);

2

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}},t=function(e){return{type:E.LEAVE,payload:e}},a=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(t(n));break;case"timeout":E(a(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}},B=function(e){return{type:E.DECRYPTION_ERROR,payload:e}},i=function(e){return{type:E.TIMEOUT_CONNECTION,payload:e}},O=function(e){return{type:E.REQUEST_MESSAGE_COUNT_EXCEED,payload:e}},s=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(B(e));break;case"PNTimeoutCategory":E(i(e));break;case"PNRequestMessageCountExceedCategory":E(O(e));break;case"PNUnknownCategory":E(s(e))}}}},b=function(e){return{message:function(t){return e({type:E.MESSAGE,payload:t})}}},I=function(e){return{signal:function(t){return e({type:E.SIGNAL,payload:t})}}},l=function(e){return{user:function(t){switch(t.event){case"update":e(function(e){return{type:E.OBJECTS_UPDATE_USER,payload:e}}({data:t.data}));break;case"delete":e(function(e){return{type:E.OBJECTS_DELETE_USER,payload:e}}({data:t.data}))}}}},f=function(e){return{space:function(t){switch(t.event){case"update":e(function(e){return{type:E.OBJECTS_UPDATE_SPACE,payload:e}}({data:t.data}));break;case"delete":e(function(e){return{type:E.OBJECTS_DELETE_SPACE,payload:e}}({data:t.data}))}}}},J=function(e){return{membership:function(t){var a={id:t.data.userId+"_"+t.data.spaceId,data:t.data};switch(t.event){case"create":e({type:E.OBJECTS_USER_ADDED_TO_SPACE,payload:a});break;case"update":e({type:E.OBJECTS_USER_MEMBERSHIP_UPDATED_ON_SPACE,payload:a});break;case"delete":e({type:E.OBJECTS_USER_REMOVED_FROM_SPACE,payload:a})}}}},A=function(){for(var E=arguments.length,e=new Array(E),t=0;t<E;t++)e[t]=arguments[t];return Object.assign.apply(Object,[{}].concat(P(e)))},P=function(E){var e=[],t={};return E.forEach(function(E){var e=Object.keys(E)[0];t.hasOwnProperty(e)||(t[e]=[]),t[e].push(E)}),Object.entries(t).forEach(function(E){var t=E[0],a=E[1];1===a.length?e.push(a[0]):a.length>1&&e.push(D(t,a))}),e},D=function(E,e){var t;return(t={})[E]=function(t){e.forEach(function(e){return e[E](t)})},t};function M(){return(M=Object.assign||function(E){for(var e=1;e<arguments.length;e++){var t=arguments[e];for(var a in t)Object.prototype.hasOwnProperty.call(t,a)&&(E[a]=t[a])}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}},H=function(e){return{type:E.OBJECTS_FETCH_USERS,payload:e}},g=function(e){return{type:E.OBJECTS_FETCH_USERS_ERROR,payload:e}},v=function(E,e){var t=x(E);return t.loadingById[e]=void 0!==t.loadingById[e]?t.loadingById[e]+1:1,delete t.errorById[e],t},F=function(E,e,t){var a=x(E);return a.loadingById[t]=a.loadingById[t]>0?a.loadingById[t]-1:0,a.errorById[t]=e,a},G=function(E,e,t){var a=x(E);return a.loadingById[t]=a.loadingById[t]>0?a.loadingById[t]-1:0,"[object Array]"===Object.prototype.toString.call(e.data)?a.byId[t]=k(e.data):"object"==typeof e.data&&(a.byId[t]=m(e.data)),a},h=function(E,e){var t=x(E);return t.byId=M({},t.byId,{},m(e.data)),t},L=function(E,e){var t=x(E);return t.loadingById[e]=t.loadingById[e]>0?t.loadingById[e]-1:0,delete t.byId[e],t},x=function(E){var e={byId:{},loadingById:M({},E.loadingById),errorById:{}};return Object.keys(E.byId).forEach(function(t){"[object Array]"===Object.prototype.toString.call(E.byId[t])?e.byId[t]=k(E.byId[t]):"object"==typeof E.byId[t]&&(e.byId[t]=m(E.byId[t]))}),Object.keys(E.errorById).forEach(function(t){e.errorById[t]=m(E.errorById[t])}),e},m=function E(e){var t=M({},e);for(var a in e)e.hasOwnProperty(a)&&("[object Array]"===Object.prototype.toString.call(e[a])?t[a]=k(e[a]):"object"==typeof e[a]&&(t[a]=E(e[a])));return t},k=function E(e){for(var t=[].concat(e),a=0;a<t.length;a++){var r=t[a];"[object Array]"===Object.prototype.toString.call(r)?t[a]=E(r):"object"==typeof t[a]&&(t[a]=m(r))}return t};exports.accessDenied=T,exports.addMembers=function(e,t){return function(a){a({type:E.OBJECTS_ADD_MEMBERS_BEGIN,payload:t}),e.addMembers(M({},t),function(e,r){if(e.error){var n={id:t.spaceId,value:M({},t)};a({type:E.OBJECTS_ADD_MEMBERS_ERROR,payload:{code:e.category,message:e.errorData,data:n}})}else a({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,t){switch(void 0===e&&(e={byId:{},loadingById:{},errorById:{}}),t.type){case E.OBJECTS_USER_ADDED_TO_SPACE:return function(E,e){var t=M({},E);Object.keys(t.byId).forEach(function(E){t.byId[E]=[].concat(t.byId[E])});var a=t.byId[e.data.userId];return void 0===a?t.byId[e.data.userId]=[{id:e.data.spaceId}]:0===a.filter(function(E){return E.id===e.data.spaceId}).length&&a.push({id:e.data.spaceId}),t}(e,t.payload);case E.OBJECTS_USER_REMOVED_FROM_SPACE:return function(E,e){var t=M({},E);return Object.keys(t.byId).forEach(function(e){t.byId[e]=[].concat(E.byId[e])}),void 0!==t.byId[e.data.userId]&&(t.byId[e.data.userId]=t.byId[e.data.userId].filter(function(E){return E.id!==e.data.spaceId})),t}(e,t.payload);case E.OBJECTS_USER_MEMBERSHIP_UPDATED_ON_SPACE:return function(E,e){var t=M({},E);return Object.keys(t.byId).forEach(function(e){t.byId[e]=[].concat(E.byId[e])}),void 0!==t.byId[e.data.userId]&&t.byId[e.data.userId].filter(function(E){return E.id===e.data.spaceId}),t}(e,t.payload);case E.OBJECTS_FETCH_MEMBERSHIPS_BEGIN:return function(E,e){return v(E,t.payload)}(e);case E.OBJECTS_FETCH_MEMBERSHIPS:return function(E,e){return G(E,{data:e.data.spaces},e.data.id)}(e,t.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,t.payload);case E.OBJECTS_UPDATE_MEMBERSHIP_BEGIN:return function(E,e){return v(E,t.payload)}(e);case E.OBJECTS_UPDATE_MEMBERSHIP:return function(E,e){return G(E,{data:e.data.spaces},e.data.userId)}(e,t.payload);case E.OBJECTS_UPDATE_MEMBERSHIP_ERROR:return function(E,e){return F(E,e,e.data.id)}(e,t.payload);case E.OBJECTS_JOIN_SPACES_BEGIN:return function(E,e){return v(E,t.payload)}(e);case E.OBJECTS_SPACES_JOINED:return function(E,e){return G(E,{data:e.data.spaces},e.data.userId)}(e,t.payload);case E.OBJECTS_JOIN_SPACES_ERROR:return function(E,e){return F(E,e,e.data.id)}(e,t.payload);case E.OBJECTS_LEAVE_SPACES_BEGIN:return function(E,e){return v(E,t.payload)}(e);case E.OBJECTS_SPACES_LEFT:return function(E,e){return G(E,{data:e.data.spaces},e.data.userId)}(e,t.payload);case E.OBJECTS_LEAVE_SPACES_ERROR:return function(E,e){return F(E,e,e.data.id)}(e,t.payload);default:return e}}},exports.createMessageActionListener=b,exports.createNetworkStatusActionListener=u,exports.createNetworkStatusReducer=function(e){var t;if("boolean"==typeof e)t={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(t={isConnected:e()}).isConnected)throw new Error("The initializer function must return a boolean value (true or false)")}return function(e,a){switch(void 0===e&&(e=t),a.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,t){return function(a){a({type:E.OBJECTS_CREATE_SPACE_BEGIN,payload:t}),e.createSpace(M({},t),function(e,r){a(e.error?{type:E.OBJECTS_CREATE_SPACE_ERROR,payload:{code:e.category,message:e.errorData,data:{id:t.id,value:t}}}:{type:E.OBJECTS_CREATE_SPACE,payload:{data:r.data}})})}},exports.createSpaceActionListener=f,exports.createSpaceListReducer=function(e){return void 0===e&&(e="all"),function(t,a){if(void 0===t&&(t={data:[],loading:!1,error:void 0}),void 0===a.payload||a.payload.label!==e)return t;switch(a.type){case E.OBJECTS_FETCH_SPACES_BEGIN:return function(E){return{data:[].concat(E.data),loading:!0,error:void 0}}(t);case E.OBJECTS_FETCH_SPACES:return r=a.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}}(t,a.payload);default:return t}var r}},exports.createSpaceReducer=function(){return function(e,t){switch(void 0===e&&(e={byId:{},loadingById:{},errorById:{}}),t.type){case E.OBJECTS_CREATE_SPACE_BEGIN:return function(E,e){return v(E,t.payload.id)}(e);case E.OBJECTS_CREATE_SPACE:return function(E,e){return G(E,e,e.data.id)}(e,t.payload);case E.OBJECTS_CREATE_SPACE_ERROR:return function(E,e){return F(E,e,e.data.id)}(e,t.payload);case E.OBJECTS_UPDATE_SPACE_BEGIN:return function(E,e){return v(E,t.payload.id)}(e);case E.OBJECTS_UPDATE_SPACE:return function(E,e){return G(E,e,e.data.id)}(e,t.payload);case E.OBJECTS_UPDATE_SPACE_ERROR:return function(E,e){return F(E,e,e.data.id)}(e,t.payload);case E.OBJECTS_DELETE_SPACE_BEGIN:return function(E,e){return v(E,t.payload)}(e);case E.OBJECTS_DELETE_SPACE:return function(E,e){return L(E,t.payload.data.id)}(e);case E.OBJECTS_DELETE_SPACE_ERROR:return function(E,e){return F(E,e,e.data.id)}(e,t.payload);case E.OBJECTS_FETCH_SPACES_BEGIN:return e;case E.OBJECTS_FETCH_SPACES:return function(E,e){return h(E,t.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,t.payload)}(e);case E.OBJECTS_FETCH_SPACE_BY_ID:return function(E,e){return G(E,e,e.data.id)}(e,t.payload);case E.OBJECTS_FETCH_SPACE_BY_ID_ERROR:return function(E,e){return F(E,e,e.data.id)}(e,t.payload);case E.OBJECTS_FETCH_MEMBERSHIPS:return function(E,e){var t=E;if(e.data.spaces.length>0)for(var a=0;a<e.data.spaces.length;a++){var r=e.data.spaces[a].space;void 0!==r&&(t=G(t,{data:r},r.id))}return t}(e,t.payload);default:return e}}},exports.createSubscribeStatusActionListener=c,exports.createUser=function(e,t){return function(a){a({type:E.OBJECTS_CREATE_USER_BEGIN,payload:t}),e.createUser(M({},t),function(e,r){a(e.error?{type:E.OBJECTS_CREATE_USER_ERROR,payload:{code:e.category,message:e.errorData,data:{id:t.id,value:t}}}:{type:E.OBJECTS_CREATE_USER,payload:{data:r.data}})})}},exports.createUserActionListener=l,exports.createUserListReducer=function(e){return void 0===e&&(e="all"),function(t,a){if(void 0===t&&(t={data:[],loading:!1,error:void 0}),void 0===a.payload||a.payload.label!==e)return t;switch(a.type){case E.OBJECTS_FETCH_USERS_BEGIN:return function(E){return{data:[].concat(E.data),loading:!0,error:void 0}}(t);case E.OBJECTS_FETCH_USERS:return r=a.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}}(t,a.payload);default:return t}var r}},exports.createUserReducer=function(){return function(e,t){switch(void 0===e&&(e={byId:{},loadingById:{},errorById:{}}),t.type){case E.OBJECTS_CREATE_USER_BEGIN:return function(E,e){return v(E,t.payload.id)}(e);case E.OBJECTS_CREATE_USER:return function(E,e){return G(E,e,e.data.id)}(e,t.payload);case E.OBJECTS_CREATE_USER_ERROR:return function(E,e){return F(E,e,e.data.id)}(e,t.payload);case E.OBJECTS_UPDATE_USER_BEGIN:return function(E,e){return v(E,t.payload.id)}(e);case E.OBJECTS_UPDATE_USER:return function(E,e){return G(E,e,e.data.id)}(e,t.payload);case E.OBJECTS_UPDATE_USER_ERROR:return function(E,e){return F(E,e,e.data.id)}(e,t.payload);case E.OBJECTS_DELETE_USER_BEGIN:return function(E,e){return v(E,t.payload)}(e);case E.OBJECTS_DELETE_USER:return function(E,e){return L(E,t.payload.data.id)}(e);case E.OBJECTS_DELETE_USER_ERROR:return function(E,e){return F(E,e,e.data.id)}(e,t.payload);case E.OBJECTS_FETCH_USERS_BEGIN:return e;case E.OBJECTS_FETCH_USERS:return function(E,e){return h(E,t.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,t.payload)}(e);case E.OBJECTS_FETCH_USER_BY_ID:return function(E,e){return G(E,e,e.data.id)}(e,t.payload);case E.OBJECTS_FETCH_USER_BY_ID_ERROR:return function(E,e){return F(E,e,e.data.id)}(e,t.payload);case E.OBJECTS_FETCH_MEMBERS:return function(E,e){var t=E;if(e.data.users.length>0)for(var a=0;a<e.data.users.length;a++){var r=e.data.users[a].user;void 0!==r&&(t=G(t,{data:r},r.id))}return t}(e,t.payload);default:return e}}},exports.decryptionError=B,exports.fetchMembers=function(e,t,a){return void 0===a&&(a={}),function(r){r({type:E.OBJECTS_FETCH_MEMBERS_BEGIN,payload:t}),e.getMembers(M({spaceId:t},a),function(e,a){r(e.error?{type:E.OBJECTS_FETCH_MEMBERS_ERROR,payload:{code:e.category,message:e.errorData,data:{id:t}}}:{type:E.OBJECTS_FETCH_MEMBERS,payload:{data:{id:t,users:a.data}}})})}},exports.fetchMemberships=function(e,t,a){return void 0===a&&(a={}),function(r){r({type:E.OBJECTS_FETCH_MEMBERSHIPS_BEGIN,payload:t}),e.getMemberships(M({userId:t},a),function(e,a){r(e.error?{type:E.OBJECTS_FETCH_MEMBERSHIPS_ERROR,payload:{code:e.category,message:e.errorData,data:{id:t}}}:{type:E.OBJECTS_FETCH_MEMBERSHIPS,payload:{data:{id:t,spaces:a.data}}})})}},exports.fetchSpaceById=function(e,t,a){return function(r){r({type:E.OBJECTS_FETCH_SPACE_BY_ID_BEGIN,payload:t}),e.getSpace(M({spaceId:t},a),function(e,a){r(e.error?{type:E.OBJECTS_FETCH_SPACE_BY_ID_ERROR,payload:{code:e.category,message:e.errorData,data:{id:t}}}:{type:E.OBJECTS_FETCH_SPACE_BY_ID,payload:{data:a.data}})})}},exports.fetchSpaces=function(e,t,a){return void 0===t&&(t={}),void 0===a&&(a="all"),function(r){r({type:E.OBJECTS_FETCH_SPACES_BEGIN,payload:{label:a}}),e.getSpaces(M({},t),function(E,e){r(E.error?U({code:E.category,message:E.errorData,data:{id:""},label:a}):N({label:a,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,t,a){return function(r){r({type:E.OBJECTS_FETCH_USER_BY_ID_BEGIN,payload:t}),e.getUser(M({userId:t},a),function(e,a){r(e.error?{type:E.OBJECTS_FETCH_USER_BY_ID_ERROR,payload:{code:e.category,message:e.errorData,data:{id:t}}}:{type:E.OBJECTS_FETCH_USER_BY_ID,payload:{data:a.data}})})}},exports.fetchUsers=function(e,t,a){return void 0===t&&(t={}),void 0===a&&(a="all"),function(r){r({type:E.OBJECTS_FETCH_USERS_BEGIN,payload:{label:a}}),e.getUsers(M({},t),function(E,e){r(E.error?g({code:E.category,message:E.errorData,data:{id:""},label:a}):H({label:a,data:e.data.reduce(function(E,e){return E[e.id]=e,E},{})}))})}},exports.fetchUsersError=g,exports.joinSpaces=function(e,t){return function(a){a({type:E.OBJECTS_JOIN_SPACES_BEGIN,payload:t}),e.joinSpaces(M({},t),function(e,r){if(e.error){var n={id:t.userId,value:M({},t)};a({type:E.OBJECTS_JOIN_SPACES_ERROR,payload:{code:e.category,message:e.errorData,data:n}})}else a({type:E.OBJECTS_SPACES_JOINED,payload:{data:r.data}})})}},exports.leaveSpaces=function(e,t){return function(a){a({type:E.OBJECTS_LEAVE_SPACES_BEGIN,payload:t}),e.leaveSpaces(M({},t),function(e,r){if(e.error){var n={id:t.userId,value:M({},t)};a({type:E.OBJECTS_LEAVE_SPACES_ERROR,payload:{code:e.category,message:e.errorData,data:n}})}else a({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,t){return function(a){a({type:E.OBJECTS_REMOVE_MEMBERS_BEGIN,payload:t}),e.removeMembers(M({},t),function(e,r){if(e.error){var n={id:t.spaceId,value:M({},t)};a({type:E.OBJECTS_REMOVE_MEMBERS_ERROR,payload:{code:e.category,message:e.errorData,data:n}})}else a({type:E.OBJECTS_MEMBERS_REMOVED,payload:{data:r.data}})})}},exports.requestMessageCountExceed=O,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=s,exports.updateMembers=function(e,t){return function(a){a({type:E.OBJECTS_UPDATE_MEMBERS_BEGIN,payload:t.spaceId}),e.updateMembers(M({},t),function(e,r){if(e.error){var n={id:t.spaceId,value:M({},t)};a({type:E.OBJECTS_UPDATE_MEMBERS_ERROR,payload:{code:e.category,message:e.errorData,data:n}})}else a({type:E.OBJECTS_UPDATE_MEMBERS,payload:{data:r.data}})})}},exports.updateMembership=function(e,t){return function(a){a({type:E.OBJECTS_UPDATE_MEMBERSHIP_BEGIN,payload:t.userId}),e.updateMembership(M({},t),function(e,r){if(e.error){var n={id:t.userId,value:M({},t)};a({type:E.OBJECTS_UPDATE_MEMBERSHIP_ERROR,payload:{code:e.category,message:e.errorData,data:n}})}else a({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=t,exports.userListRetrieved=H,exports.userStateChange=r,exports.userTimeout=a,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}},t=function(e){return{type:E.LEAVE,payload:e}},a=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(t(n));break;case"timeout":E(a(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}},B=function(e){return{type:E.DECRYPTION_ERROR,payload:e}},i=function(e){return{type:E.TIMEOUT_CONNECTION,payload:e}},s=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(B(e));break;case"PNTimeoutCategory":E(i(e));break;case"PNRequestMessageCountExceedCategory":E(s(e));break;case"PNUnknownCategory":E(O(e))}}}},b=function(e){return{message:function(t){return e({type:E.MESSAGE,payload:t})}}},I=function(e){return{signal:function(t){return e({type:E.SIGNAL,payload:t})}}},l=function(e){return{user:function(t){switch(t.event){case"update":e(function(e){return{type:E.OBJECTS_UPDATE_USER,payload:e}}({data:t.data}));break;case"delete":e(function(e){return{type:E.OBJECTS_DELETE_USER,payload:e}}({data:t.data}))}}}},f=function(e){return{space:function(t){switch(t.event){case"update":e(function(e){return{type:E.OBJECTS_UPDATE_SPACE,payload:e}}({data:t.data}));break;case"delete":e(function(e){return{type:E.OBJECTS_DELETE_SPACE,payload:e}}({data:t.data}))}}}},J=function(e){return{membership:function(t){var a={id:t.data.userId+"_"+t.data.spaceId,data:t.data};switch(t.event){case"create":e({type:E.OBJECTS_USER_ADDED_TO_SPACE,payload:a});break;case"update":e({type:E.OBJECTS_USER_MEMBERSHIP_UPDATED_ON_SPACE,payload:a});break;case"delete":e({type:E.OBJECTS_USER_REMOVED_FROM_SPACE,payload:a})}}}},A=function(){for(var E=arguments.length,e=new Array(E),t=0;t<E;t++)e[t]=arguments[t];return Object.assign.apply(Object,[{}].concat(P(e)))},P=function(E){var e=[],t={};return E.forEach(function(E){var e=Object.keys(E)[0];t.hasOwnProperty(e)||(t[e]=[]),t[e].push(E)}),Object.entries(t).forEach(function(E){var t=E[0],a=E[1];1===a.length?e.push(a[0]):a.length>1&&e.push(D(t,a))}),e},D=function(E,e){var t;return(t={})[E]=function(t){e.forEach(function(e){return e[E](t)})},t};function M(){return(M=Object.assign||function(E){for(var e=1;e<arguments.length;e++){var t=arguments[e];for(var a in t)Object.prototype.hasOwnProperty.call(t,a)&&(E[a]=t[a])}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}},H=function(e){return{type:E.OBJECTS_FETCH_USERS,payload:e}},g=function(e){return{type:E.OBJECTS_FETCH_USERS_ERROR,payload:e}},v=function(E,e){var t=x(E);return t.loadingById[e]=void 0!==t.loadingById[e]?t.loadingById[e]+1:1,delete t.errorById[e],t},F=function(E,e,t){var a=x(E);return a.loadingById[t]=a.loadingById[t]>0?a.loadingById[t]-1:0,a.errorById[t]=e,a},G=function(E,e,t){var a=x(E);return a.loadingById[t]=a.loadingById[t]>0?a.loadingById[t]-1:0,"[object Array]"===Object.prototype.toString.call(e.data)?a.byId[t]=k(e.data):"object"==typeof e.data&&(a.byId[t]=m(e.data)),a},h=function(E,e){var t=x(E);return t.byId=M({},t.byId,{},m(e.data)),t},L=function(E,e){var t=x(E);return t.loadingById[e]=t.loadingById[e]>0?t.loadingById[e]-1:0,delete t.byId[e],t},x=function(E){var e={byId:{},loadingById:M({},E.loadingById),errorById:{}};return Object.keys(E.byId).forEach(function(t){"[object Array]"===Object.prototype.toString.call(E.byId[t])?e.byId[t]=k(E.byId[t]):"object"==typeof E.byId[t]&&(e.byId[t]=m(E.byId[t]))}),Object.keys(E.errorById).forEach(function(t){e.errorById[t]=m(E.errorById[t])}),e},m=function E(e){var t=M({},e);for(var a in e)e.hasOwnProperty(a)&&("[object Array]"===Object.prototype.toString.call(e[a])?t[a]=k(e[a]):"object"==typeof e[a]&&(t[a]=E(e[a])));return t},k=function E(e){for(var t=[].concat(e),a=0;a<t.length;a++){var r=t[a];"[object Array]"===Object.prototype.toString.call(r)?t[a]=E(r):"object"==typeof t[a]&&(t[a]=m(r))}return t};exports.accessDenied=T,exports.addMembers=function(e,t){return function(a){a({type:E.OBJECTS_ADD_MEMBERS_BEGIN,payload:t}),e.addMembers(M({},t),function(e,r){if(e.error){var n={id:t.spaceId,value:M({},t)};a({type:E.OBJECTS_ADD_MEMBERS_ERROR,payload:{code:e.category,message:e.errorData,data:n}})}else a({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,t){switch(void 0===e&&(e={byId:{},loadingById:{},errorById:{}}),t.type){case E.OBJECTS_USER_ADDED_TO_SPACE:return function(E,e){var t=M({},E);console.log("user added to space",JSON.stringify(e)),Object.keys(t.byId).forEach(function(E){t.byId[E]=[].concat(t.byId[E])});var a=t.byId[e.data.userId];return void 0===a?t.byId[e.data.userId]=[{id:e.data.spaceId}]:0===a.filter(function(E){return E.id===e.data.spaceId}).length&&a.push({id:e.data.spaceId}),t}(e,t.payload);case E.OBJECTS_USER_REMOVED_FROM_SPACE:return function(E,e){var t=M({},E);return Object.keys(t.byId).forEach(function(e){t.byId[e]=[].concat(E.byId[e])}),void 0!==t.byId[e.data.userId]&&(t.byId[e.data.userId]=t.byId[e.data.userId].filter(function(E){return E.id!==e.data.spaceId})),t}(e,t.payload);case E.OBJECTS_USER_MEMBERSHIP_UPDATED_ON_SPACE:return function(E,e){var t=M({},E);return Object.keys(t.byId).forEach(function(e){t.byId[e]=[].concat(E.byId[e])}),void 0!==t.byId[e.data.userId]&&t.byId[e.data.userId].filter(function(E){return E.id===e.data.spaceId}),t}(e,t.payload);case E.OBJECTS_FETCH_MEMBERSHIPS_BEGIN:return function(E,e){return v(E,t.payload)}(e);case E.OBJECTS_FETCH_MEMBERSHIPS:return function(E,e){return G(E,{data:e.data.spaces},e.data.id)}(e,t.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,t.payload);case E.OBJECTS_UPDATE_MEMBERSHIP_BEGIN:return function(E,e){return v(E,t.payload)}(e);case E.OBJECTS_UPDATE_MEMBERSHIP:return function(E,e){return G(E,{data:e.data.spaces},e.data.userId)}(e,t.payload);case E.OBJECTS_UPDATE_MEMBERSHIP_ERROR:return function(E,e){return F(E,e,e.data.id)}(e,t.payload);case E.OBJECTS_JOIN_SPACES_BEGIN:return function(E,e){return v(E,t.payload)}(e);case E.OBJECTS_SPACES_JOINED:return function(E,e){return G(E,{data:e.data.spaces},e.data.userId)}(e,t.payload);case E.OBJECTS_JOIN_SPACES_ERROR:return function(E,e){return F(E,e,e.data.id)}(e,t.payload);case E.OBJECTS_LEAVE_SPACES_BEGIN:return function(E,e){return v(E,t.payload)}(e);case E.OBJECTS_SPACES_LEFT:return function(E,e){return G(E,{data:e.data.spaces},e.data.userId)}(e,t.payload);case E.OBJECTS_LEAVE_SPACES_ERROR:return function(E,e){return F(E,e,e.data.id)}(e,t.payload);default:return e}}},exports.createMessageActionListener=b,exports.createNetworkStatusActionListener=u,exports.createNetworkStatusReducer=function(e){var t;if("boolean"==typeof e)t={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(t={isConnected:e()}).isConnected)throw new Error("The initializer function must return a boolean value (true or false)")}return function(e,a){switch(void 0===e&&(e=t),a.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,t){return function(a){a({type:E.OBJECTS_CREATE_SPACE_BEGIN,payload:t}),e.createSpace(M({},t),function(e,r){a(e.error?{type:E.OBJECTS_CREATE_SPACE_ERROR,payload:{code:e.category,message:e.errorData,data:{id:t.id,value:t}}}:{type:E.OBJECTS_CREATE_SPACE,payload:{data:r.data}})})}},exports.createSpaceActionListener=f,exports.createSpaceListReducer=function(e){return void 0===e&&(e="all"),function(t,a){if(void 0===t&&(t={data:[],loading:!1,error:void 0}),void 0===a.payload||a.payload.label!==e)return t;switch(a.type){case E.OBJECTS_FETCH_SPACES_BEGIN:return function(E){return{data:[].concat(E.data),loading:!0,error:void 0}}(t);case E.OBJECTS_FETCH_SPACES:return r=a.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}}(t,a.payload);default:return t}var r}},exports.createSpaceReducer=function(){return function(e,t){switch(void 0===e&&(e={byId:{},loadingById:{},errorById:{}}),t.type){case E.OBJECTS_CREATE_SPACE_BEGIN:return function(E,e){return v(E,t.payload.id)}(e);case E.OBJECTS_CREATE_SPACE:return function(E,e){return G(E,e,e.data.id)}(e,t.payload);case E.OBJECTS_CREATE_SPACE_ERROR:return function(E,e){return F(E,e,e.data.id)}(e,t.payload);case E.OBJECTS_UPDATE_SPACE_BEGIN:return function(E,e){return v(E,t.payload.id)}(e);case E.OBJECTS_UPDATE_SPACE:return function(E,e){return G(E,e,e.data.id)}(e,t.payload);case E.OBJECTS_UPDATE_SPACE_ERROR:return function(E,e){return F(E,e,e.data.id)}(e,t.payload);case E.OBJECTS_DELETE_SPACE_BEGIN:return function(E,e){return v(E,t.payload)}(e);case E.OBJECTS_DELETE_SPACE:return function(E,e){return L(E,t.payload.data.id)}(e);case E.OBJECTS_DELETE_SPACE_ERROR:return function(E,e){return F(E,e,e.data.id)}(e,t.payload);case E.OBJECTS_FETCH_SPACES_BEGIN:return e;case E.OBJECTS_FETCH_SPACES:return function(E,e){return h(E,t.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,t.payload)}(e);case E.OBJECTS_FETCH_SPACE_BY_ID:return function(E,e){return G(E,e,e.data.id)}(e,t.payload);case E.OBJECTS_FETCH_SPACE_BY_ID_ERROR:return function(E,e){return F(E,e,e.data.id)}(e,t.payload);case E.OBJECTS_FETCH_MEMBERSHIPS:return function(E,e){var t=E;if(e.data.spaces.length>0)for(var a=0;a<e.data.spaces.length;a++){var r=e.data.spaces[a].space;void 0!==r&&(t=G(t,{data:r},r.id))}return t}(e,t.payload);default:return e}}},exports.createSubscribeStatusActionListener=c,exports.createUser=function(e,t){return function(a){a({type:E.OBJECTS_CREATE_USER_BEGIN,payload:t}),e.createUser(M({},t),function(e,r){a(e.error?{type:E.OBJECTS_CREATE_USER_ERROR,payload:{code:e.category,message:e.errorData,data:{id:t.id,value:t}}}:{type:E.OBJECTS_CREATE_USER,payload:{data:r.data}})})}},exports.createUserActionListener=l,exports.createUserListReducer=function(e){return void 0===e&&(e="all"),function(t,a){if(void 0===t&&(t={data:[],loading:!1,error:void 0}),void 0===a.payload||a.payload.label!==e)return t;switch(a.type){case E.OBJECTS_FETCH_USERS_BEGIN:return function(E){return{data:[].concat(E.data),loading:!0,error:void 0}}(t);case E.OBJECTS_FETCH_USERS:return r=a.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}}(t,a.payload);default:return t}var r}},exports.createUserReducer=function(){return function(e,t){switch(void 0===e&&(e={byId:{},loadingById:{},errorById:{}}),t.type){case E.OBJECTS_CREATE_USER_BEGIN:return function(E,e){return v(E,t.payload.id)}(e);case E.OBJECTS_CREATE_USER:return function(E,e){return G(E,e,e.data.id)}(e,t.payload);case E.OBJECTS_CREATE_USER_ERROR:return function(E,e){return F(E,e,e.data.id)}(e,t.payload);case E.OBJECTS_UPDATE_USER_BEGIN:return function(E,e){return v(E,t.payload.id)}(e);case E.OBJECTS_UPDATE_USER:return function(E,e){return G(E,e,e.data.id)}(e,t.payload);case E.OBJECTS_UPDATE_USER_ERROR:return function(E,e){return F(E,e,e.data.id)}(e,t.payload);case E.OBJECTS_DELETE_USER_BEGIN:return function(E,e){return v(E,t.payload)}(e);case E.OBJECTS_DELETE_USER:return function(E,e){return L(E,t.payload.data.id)}(e);case E.OBJECTS_DELETE_USER_ERROR:return function(E,e){return F(E,e,e.data.id)}(e,t.payload);case E.OBJECTS_FETCH_USERS_BEGIN:return e;case E.OBJECTS_FETCH_USERS:return function(E,e){return h(E,t.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,t.payload)}(e);case E.OBJECTS_FETCH_USER_BY_ID:return function(E,e){return G(E,e,e.data.id)}(e,t.payload);case E.OBJECTS_FETCH_USER_BY_ID_ERROR:return function(E,e){return F(E,e,e.data.id)}(e,t.payload);case E.OBJECTS_FETCH_MEMBERS:return function(E,e){var t=E;if(e.data.users.length>0)for(var a=0;a<e.data.users.length;a++){var r=e.data.users[a].user;void 0!==r&&(t=G(t,{data:r},r.id))}return t}(e,t.payload);default:return e}}},exports.decryptionError=B,exports.fetchMembers=function(e,t,a){return void 0===a&&(a={}),function(r){r({type:E.OBJECTS_FETCH_MEMBERS_BEGIN,payload:t}),e.getMembers(M({spaceId:t},a),function(e,a){r(e.error?{type:E.OBJECTS_FETCH_MEMBERS_ERROR,payload:{code:e.category,message:e.errorData,data:{id:t}}}:{type:E.OBJECTS_FETCH_MEMBERS,payload:{data:{id:t,users:a.data}}})})}},exports.fetchMemberships=function(e,t,a){return void 0===a&&(a={}),function(r){r({type:E.OBJECTS_FETCH_MEMBERSHIPS_BEGIN,payload:t}),e.getMemberships(M({userId:t},a),function(e,a){r(e.error?{type:E.OBJECTS_FETCH_MEMBERSHIPS_ERROR,payload:{code:e.category,message:e.errorData,data:{id:t}}}:{type:E.OBJECTS_FETCH_MEMBERSHIPS,payload:{data:{id:t,spaces:a.data}}})})}},exports.fetchSpaceById=function(e,t,a){return function(r){r({type:E.OBJECTS_FETCH_SPACE_BY_ID_BEGIN,payload:t}),e.getSpace(M({spaceId:t},a),function(e,a){r(e.error?{type:E.OBJECTS_FETCH_SPACE_BY_ID_ERROR,payload:{code:e.category,message:e.errorData,data:{id:t}}}:{type:E.OBJECTS_FETCH_SPACE_BY_ID,payload:{data:a.data}})})}},exports.fetchSpaces=function(e,t,a){return void 0===t&&(t={}),void 0===a&&(a="all"),function(r){r({type:E.OBJECTS_FETCH_SPACES_BEGIN,payload:{label:a}}),e.getSpaces(M({},t),function(E,e){r(E.error?U({code:E.category,message:E.errorData,data:{id:""},label:a}):N({label:a,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,t,a){return function(r){r({type:E.OBJECTS_FETCH_USER_BY_ID_BEGIN,payload:t}),e.getUser(M({userId:t},a),function(e,a){r(e.error?{type:E.OBJECTS_FETCH_USER_BY_ID_ERROR,payload:{code:e.category,message:e.errorData,data:{id:t}}}:{type:E.OBJECTS_FETCH_USER_BY_ID,payload:{data:a.data}})})}},exports.fetchUsers=function(e,t,a){return void 0===t&&(t={}),void 0===a&&(a="all"),function(r){r({type:E.OBJECTS_FETCH_USERS_BEGIN,payload:{label:a}}),e.getUsers(M({},t),function(E,e){r(E.error?g({code:E.category,message:E.errorData,data:{id:""},label:a}):H({label:a,data:e.data.reduce(function(E,e){return E[e.id]=e,E},{})}))})}},exports.fetchUsersError=g,exports.joinSpaces=function(e,t){return function(a){a({type:E.OBJECTS_JOIN_SPACES_BEGIN,payload:t}),e.joinSpaces(M({},t),function(e,r){if(e.error){var n={id:t.userId,value:M({},t)};a({type:E.OBJECTS_JOIN_SPACES_ERROR,payload:{code:e.category,message:e.errorData,data:n}})}else a({type:E.OBJECTS_SPACES_JOINED,payload:{data:r.data}})})}},exports.leaveSpaces=function(e,t){return function(a){a({type:E.OBJECTS_LEAVE_SPACES_BEGIN,payload:t}),e.leaveSpaces({userId:t.userId,spaces:t.spaces.map(function(E){return E.id})},function(e,r){if(e.error){var n={id:t.userId,value:M({},t)};a({type:E.OBJECTS_LEAVE_SPACES_ERROR,payload:{code:e.category,message:e.errorData,data:n}})}else a({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,t){return function(a){a({type:E.OBJECTS_REMOVE_MEMBERS_BEGIN,payload:t}),e.removeMembers({spaceId:t.spaceId,users:t.users.map(function(E){return E.id})},function(e,r){if(e.error){var n={id:t.spaceId,value:M({},t)};a({type:E.OBJECTS_REMOVE_MEMBERS_ERROR,payload:{code:e.category,message:e.errorData,data:n}})}else a({type:E.OBJECTS_MEMBERS_REMOVED,payload:{data:r.data}})})}},exports.requestMessageCountExceed=s,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,t){return function(a){a({type:E.OBJECTS_UPDATE_MEMBERS_BEGIN,payload:t.spaceId}),e.updateMembers(M({},t),function(e,r){if(e.error){var n={id:t.spaceId,value:M({},t)};a({type:E.OBJECTS_UPDATE_MEMBERS_ERROR,payload:{code:e.category,message:e.errorData,data:n}})}else a({type:E.OBJECTS_UPDATE_MEMBERS,payload:{data:r.data}})})}},exports.updateMembership=function(e,t){return function(a){a({type:E.OBJECTS_UPDATE_MEMBERSHIP_BEGIN,payload:t.userId}),e.updateMembership(M({},t),function(e,r){if(e.error){var n={id:t.userId,value:M({},t)};a({type:E.OBJECTS_UPDATE_MEMBERSHIP_ERROR,payload:{code:e.category,message:e.errorData,data:n}})}else a({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=t,exports.userListRetrieved=H,exports.userStateChange=r,exports.userTimeout=a,exports.userUpdated=function(e){return{type:E.OBJECTS_UPDATE_USER,payload:e}};
//# sourceMappingURL=pubnub-redux.cjs.production.min.js.map

15

dist/pubnub-redux.esm.js

@@ -682,3 +682,8 @@ var actionType;

dispatch(leaveSpacesBegin(membership));
pubnub.leaveSpaces(_extends({}, membership), function (status, response) {
pubnub.leaveSpaces({
userId: membership.userId,
spaces: membership.spaces.map(function (space) {
return space.id;
})
}, function (status, response) {
if (status.error) {

@@ -856,3 +861,8 @@ var errorData = {

dispatch(removeMembersBegin(members));
pubnub.removeMembers(_extends({}, members), function (status, response) {
pubnub.removeMembers({
spaceId: members.spaceId,
users: members.users.map(function (user) {
return user.id;
})
}, function (status, response) {
if (status.error) {

@@ -1740,2 +1750,3 @@ var errorData = {

console.log('user added to space', JSON.stringify(payload));
Object.keys(newState.byId).forEach(function (key) {

@@ -1742,0 +1753,0 @@ newState.byId[key] = [].concat(newState.byId[key]);

32

dist/reducers/userReducer.d.ts
import { PubNubObjectApiState, Identifiable } from '../api/PubNubApi';
export declare const createUserReducer: <T extends Identifiable>() => (state: PubNubObjectApiState<T> | undefined, action: import("../actions/Actions").DeleteUserBeginAction | import("../actions/Actions").FetchUsersBeginAction | import("../actions/Actions").FetchUserByIdBeginAction | import("../actions/Actions").UserCreatedAction<T> | import("../actions/Actions").CreateUserBeginAction<T> | import("../actions/Actions").CreateUserErrorAction<T> | import("../actions/Actions").UserUpdatedAction<T> | import("../actions/Actions").UpdateUserBeginAction<T> | import("../actions/Actions").UpdateUserErrorAction<T> | import("../actions/Actions").UserDeletedAction<T> | import("../actions/Actions").DeleteUserErrorAction<T> | import("../actions/Actions").UserListRetrievedAction<T> | import("../actions/Actions").FetchUsersErrorAction<T> | import("../actions/Actions").FetchUserByIdAction<T> | import("../actions/Actions").FetchUserByIdErrorAction<T> | import("../actions/Actions").FetchMembersBeginAction | import("../actions/Actions").FetchMembersAction | import("../actions/Actions").FetchMembersErrorAction<{
id: string;
user?: import("..").User | undefined;
}[]> | import("../actions/Actions").UpdateMembersBeginAction<{
id: string;
user?: import("..").User | undefined;
}[]> | import("../actions/Actions").MembersUpdatedAction<{
id: string;
user?: import("..").User | undefined;
}[]> | import("../actions/Actions").UpdateMembersErrorAction<{
id: string;
user?: import("..").User | undefined;
}[]> | import("../actions/Actions").AddMembersBeginAction<{
id: string;
user?: import("..").User | undefined;
}[]> | import("../actions/Actions").MembersAddedAction<{
id: string;
user?: import("..").User | undefined;
}[]> | import("../actions/Actions").AddMembersErrorAction<{
id: string;
user?: import("..").User | undefined;
}[]> | import("../actions/Actions").RemoveMembersBeginAction<{
id: string;
user?: import("..").User | undefined;
}[]> | import("../actions/Actions").MembersRemovedAction<{
id: string;
user?: import("..").User | undefined;
}[]> | import("../actions/Actions").RemoveMembersErrorAction<{
id: string;
user?: import("..").User | undefined;
}[]>) => PubNubObjectApiState<T>;
export declare const createUserReducer: <T extends Identifiable>() => (state: PubNubObjectApiState<T> | undefined, action: any) => PubNubObjectApiState<T>;

2

package.json
{
"name": "pubnub-redux",
"version": "0.1.10-alpha",
"version": "0.1.11-alpha",
"main": "dist/index.js",

@@ -5,0 +5,0 @@ "module": "dist/reduxsdk.esm.js",

dist/pubnub-redux.cjs.development.js.map

Sorry, the diff of this file is not supported yet

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

Sorry, the diff of this file is not supported yet

dist/pubnub-redux.esm.js.map

Sorry, the diff of this file is not supported yet

SocketSocket SOC 2 Logo

Product

  • Package Alerts
  • Integrations
  • Docs
  • Pricing
  • FAQ
  • Roadmap
  • Changelog

About

Packages

npm

Go

Maven

PyPI

Rubygems

Stay in touch

Get open source security insights delivered straight into your inbox.

  • Terms
  • Privacy
  • Security

Made with ⚡️ by Socket Inc