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.4-alpha to 0.1.5-alpha

dist/reducers/spaceListReducer.d.ts

4

dist/actions/MembershipActions.d.ts

@@ -8,6 +8,6 @@ import { ObjectsActionPayload, ObjectsListInput } from '../types/Objects';

export declare const userRemovedFromSpace: <T extends Identifiable>(payload: ObjectsActionPayload<T>) => UserRemovedFromSpaceAction<T>;
export declare const getMembers: (pubnub: any, spaceId: string, options?: ObjectsListInput | undefined) => (dispatch: Dispatch<import("redux").AnyAction>) => void;
export declare const getMemberships: (pubnub: any, userId: string, options?: ObjectsListInput | undefined) => (dispatch: Dispatch<import("redux").AnyAction>) => void;
export declare const fetchMembers: (pubnub: any, spaceId: string, options?: ObjectsListInput | undefined) => (dispatch: Dispatch<import("redux").AnyAction>) => void;
export declare const fetchMemberships: (pubnub: any, userId: string, options?: ObjectsListInput | undefined) => (dispatch: Dispatch<import("redux").AnyAction>) => void;
export declare const createMembershipActionListener: <T extends Identifiable>(dispatch: Dispatch<MembershipListenerActions<T>>) => {
membership: (payload: ObjectsActionPayload<T>) => void;
};

34

dist/actions/SpaceActions.d.ts
import { ObjectsActionPayload, ObjectsListInput } from '../types/Objects';
import { SpaceDeletedAction, SpaceUpdatedAction, CreateSpaceErrorAction, GetSpaceByIdErrorAction, GetSpacesErrorAction, GetSpaceByIdAction, SpaceListRetrievedAction, SpaceCreatedAction, CreateSpaceBeginAction, GetSpacesBeginAction, GetSpaceByIdBeginAction, UpdateSpaceBeginAction, UpdateSpaceErrorAction, DeleteSpaceBeginAction, DeleteSpaceErrorAction } from '../types/actions';
import { SpaceDeletedAction, SpaceUpdatedAction, CreateSpaceErrorAction, FetchSpaceByIdErrorAction, FetchSpacesErrorAction, FetchSpaceByIdAction, SpaceListRetrievedAction, SpaceCreatedAction, CreateSpaceBeginAction, FetchSpacesBeginAction, FetchSpaceByIdBeginAction, UpdateSpaceBeginAction, UpdateSpaceErrorAction, DeleteSpaceBeginAction, DeleteSpaceErrorAction } from '../types/actions';
import { Dispatch } from 'redux';
import { Space, SpaceMap } from '../types/Space';
import { PubNubApiSuccess, PubNubApiError, Identifiable } from 'types/PubNubApi';
import { PubNubObjectApiSuccess, PubNubObjectApiError, Identifiable } from 'types/PubNubApi';
export declare const createSpaceBegin: <T>(payload: T) => CreateSpaceBeginAction<T>;
export declare const spaceCreated: <T>(payload: PubNubApiSuccess<T>) => SpaceCreatedAction<T>;
export declare const createSpaceError: <T>(payload: PubNubApiError<T>) => CreateSpaceErrorAction<T>;
export declare const spaceListRetrieved: <T>(payload: PubNubApiSuccess<SpaceMap<T>>) => SpaceListRetrievedAction<T>;
export declare const getSpacesBegin: () => GetSpacesBeginAction;
export declare const getSpacesError: (payload: PubNubApiError<object>) => GetSpacesErrorAction;
export declare const spaceRetrievedById: <T>(payload: PubNubApiSuccess<T>) => GetSpaceByIdAction<T>;
export declare const getSpaceByIdBegin: (payload: string) => GetSpaceByIdBeginAction;
export declare const getSpaceByIdError: <T>(payload: PubNubApiError<T>) => GetSpaceByIdErrorAction<T>;
export declare const spaceUpdated: <T>(payload: PubNubApiSuccess<T>) => SpaceUpdatedAction<T>;
export declare const spaceCreated: <T>(payload: PubNubObjectApiSuccess<T>) => SpaceCreatedAction<T>;
export declare const createSpaceError: <T>(payload: PubNubObjectApiError<T>) => CreateSpaceErrorAction<T>;
export declare const spaceListRetrieved: <T>(payload: PubNubObjectApiSuccess<SpaceMap<T>>) => SpaceListRetrievedAction<T>;
export declare const fetchSpacesBegin: (payload: {
label: string;
}) => FetchSpacesBeginAction;
export declare const fetchSpacesError: (payload: PubNubObjectApiError<object>) => FetchSpacesErrorAction;
export declare const spaceRetrievedById: <T>(payload: PubNubObjectApiSuccess<T>) => FetchSpaceByIdAction<T>;
export declare const fetchSpaceByIdBegin: (payload: string) => FetchSpaceByIdBeginAction;
export declare const fetchSpaceByIdError: <T>(payload: PubNubObjectApiError<T>) => FetchSpaceByIdErrorAction<T>;
export declare const spaceUpdated: <T>(payload: PubNubObjectApiSuccess<T>) => SpaceUpdatedAction<T>;
export declare const updateSpaceBegin: <T>(payload: T) => UpdateSpaceBeginAction<T>;
export declare const updateSpaceError: <T>(payload: PubNubApiError<T>) => UpdateSpaceErrorAction<T>;
export declare const spaceDeleted: <T>(payload: PubNubApiSuccess<T>) => SpaceDeletedAction<T>;
export declare const updateSpaceError: <T>(payload: PubNubObjectApiError<T>) => UpdateSpaceErrorAction<T>;
export declare const spaceDeleted: <T>(payload: PubNubObjectApiSuccess<T>) => SpaceDeletedAction<T>;
export declare const deleteSpaceBegin: (payload: string) => DeleteSpaceBeginAction;
export declare const deleteSpaceError: <T>(payload: PubNubApiError<T>) => DeleteSpaceErrorAction<T>;
export declare const deleteSpaceError: <T>(payload: PubNubObjectApiError<T>) => DeleteSpaceErrorAction<T>;
export declare const createSpace: (pubnub: any, id: string, name: string, space: Space) => (dispatch: Dispatch<import("redux").AnyAction>) => void;
export declare const updateSpace: (pubnub: any, id: string, name: string, space: Space) => (dispatch: Dispatch<import("redux").AnyAction>) => void;
export declare const deleteSpace: (pubnub: any, id: string) => (dispatch: Dispatch<import("redux").AnyAction>) => void;
export declare const getSpaces: (pubnub: any, options?: ObjectsListInput | undefined) => (dispatch: Dispatch<import("redux").AnyAction>) => void;
export declare const getSpaceById: (pubnub: any, spaceId: string, include?: object | undefined) => (dispatch: Dispatch<import("redux").AnyAction>) => void;
export declare const fetchSpaces: (pubnub: any, options?: ObjectsListInput, label?: string) => (dispatch: Dispatch<import("redux").AnyAction>) => void;
export declare const fetchSpaceById: (pubnub: any, spaceId: string, include?: object | undefined) => (dispatch: Dispatch<import("redux").AnyAction>) => void;
export declare const createSpaceActionListener: <T extends Identifiable>(dispatch: Dispatch<SpaceUpdatedAction<T> | SpaceDeletedAction<T>>) => {
space: (payload: ObjectsActionPayload<T>) => void;
};

12

dist/actions/UserActions.d.ts

@@ -1,2 +0,2 @@

import { UserUpdatedAction, UserDeletedAction, UserCreatedAction, UserListRetrievedAction, GetUserByIdAction, GetUsersErrorAction, GetUserByIdErrorAction, CreateUserErrorAction } from '../types/actions';
import { UserUpdatedAction, UserDeletedAction, UserCreatedAction, UserListRetrievedAction, FetchUserByIdAction, FetchUsersErrorAction, FetchUserByIdErrorAction, CreateUserErrorAction } from '../types/actions';
import { Dispatch } from 'redux';

@@ -8,11 +8,11 @@ import { User, CreateUserInput, UserStatusPayload, UsersListInput, UserActionPayload } from '../types/User';

export declare const userListRetrieved: (payload: User[]) => UserListRetrievedAction;
export declare const userRetrievedById: (payload: User) => GetUserByIdAction;
export declare const getUsersError: (payload: UserStatusPayload) => GetUsersErrorAction;
export declare const getUserByIdError: (payload: UserStatusPayload) => GetUserByIdErrorAction;
export declare const userRetrievedById: (payload: User) => FetchUserByIdAction;
export declare const fetchUsersError: (payload: UserStatusPayload) => FetchUsersErrorAction;
export declare const fetchUserByIdError: (payload: UserStatusPayload) => FetchUserByIdErrorAction;
export declare const createUserError: (payload: UserStatusPayload) => CreateUserErrorAction;
export declare const createUser: (pubnub: any, id: string, name: string, options?: CreateUserInput | undefined) => (dispatch: Dispatch<UserCreatedAction | CreateUserErrorAction>) => void;
export declare const getUsers: (pubnub: any, options?: UsersListInput | undefined) => (dispatch: Dispatch<UserListRetrievedAction | GetUsersErrorAction>) => void;
export declare const getUserById: (pubnub: any, userId: string, include?: object | undefined) => (dispatch: Dispatch<GetUserByIdAction | GetUserByIdErrorAction>) => void;
export declare const fetchUsers: (pubnub: any, options?: UsersListInput | undefined) => (dispatch: Dispatch<UserListRetrievedAction | FetchUsersErrorAction>) => void;
export declare const fetchUserById: (pubnub: any, userId: string, include?: object | undefined) => (dispatch: Dispatch<FetchUserByIdAction | FetchUserByIdErrorAction>) => void;
export declare const createUserActionListener: (dispatch: Dispatch<UserUpdatedAction | UserDeletedAction>) => {
user: (payload: UserActionPayload) => void;
};

14

dist/index.d.ts
import { createPubNubActionListener, combineListeners } from './actions/ListenerAction';
import { userMembershipUpdatedOnSpace, userAddedToSpace, userRemovedFromSpace, createMembershipActionListener, getMembers, getMemberships } from './actions/MembershipActions';
import { userMembershipUpdatedOnSpace, userAddedToSpace, userRemovedFromSpace, createMembershipActionListener, fetchMembers, fetchMemberships } from './actions/MembershipActions';
import { createMessageActionListener } from './actions/MessageActions';
import { createPresenceActionListener, userJoin, userLeave, userStateChange, userTimeout } from './actions/PresenceActions';
import { createSignalActionListener } from './actions/SignalActions';
import { createSpaceActionListener, spaceDeleted, spaceUpdated, getSpaces, spaceListRetrieved, getSpacesError, createSpace, getSpaceById } from './actions/SpaceActions';
import { createSpaceActionListener, spaceDeleted, spaceUpdated, fetchSpaces, spaceListRetrieved, fetchSpacesError, createSpace, fetchSpaceById } from './actions/SpaceActions';
import { createNetworkStatusActionListener, networkDown, networkUp } from './actions/NetworkStatusActions';
import { createSubscribeStatusActionListener, reconnected, connected } from './actions/SubscribeStatusActions';
import { createErrorStatusActionListener, timeoutConnection, accessDenied, networkIssues, malformedResponse, badRequest, decryptionError, requestMessageCountExceed, unknown } from './actions/ErrorStatusActions';
import { createUserActionListener, userUpdated, userDeleted, createUser, getUsers, userListRetrieved, getUsersError, getUserById } from './actions/UserActions';
import { createUserActionListener, userUpdated, userDeleted, createUser, fetchUsers, userListRetrieved, fetchUsersError, fetchUserById } from './actions/UserActions';
import { createNetworkStatusReducer } from './reducers/createNetworkStatusReducer';
import { userReducer } from './reducers/userReducer';
import { createSpaceReducer } from './reducers/spaceReducer';
import { createSpaceListReducer } from './reducers/spaceListReducer';
import { membershipReducer } from './reducers/membershipReducer';
import { Identifiable, PubNubApiState } from './types/PubNubApi';
import { Space, SpaceMap } from './types/Space';
export { Identifiable, PubNubApiState, Space, SpaceMap, createPubNubActionListener, createMembershipActionListener, userMembershipUpdatedOnSpace, userAddedToSpace, userRemovedFromSpace, getMembers, getMemberships, createMessageActionListener, createPresenceActionListener, userJoin, userLeave, userStateChange, userTimeout, createSignalActionListener, createSpaceActionListener, spaceDeleted, spaceUpdated, getSpaces, spaceListRetrieved, getSpacesError, createSpace, getSpaceById, createNetworkStatusActionListener, createSubscribeStatusActionListener, createErrorStatusActionListener, networkDown, networkUp, networkIssues, reconnected, connected, timeoutConnection, accessDenied, malformedResponse, badRequest, decryptionError, requestMessageCountExceed, unknown, createUserActionListener, userUpdated, userDeleted, createUser, getUsers, getUserById, userListRetrieved, getUsersError, createNetworkStatusReducer, userReducer, createSpaceReducer, membershipReducer, combineListeners, };
import { Identifiable, PubNubObjectApiState } from './types/PubNubApi';
import { Space } from './types/Space';
import { SpaceListState } from './reducers/spaceListReducer';
export { Identifiable, PubNubObjectApiState as PubNubApiState, Space, SpaceListState, createPubNubActionListener, createMembershipActionListener, userMembershipUpdatedOnSpace, userAddedToSpace, userRemovedFromSpace, fetchMembers, fetchMemberships, 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, userReducer, createSpaceReducer, createSpaceListReducer, membershipReducer, combineListeners, };

269

dist/pubnub-redux.cjs.development.js

@@ -24,6 +24,6 @@ 'use strict';

var OBJECTS_CREATE_USER_ERROR = 'pubnub/OBJECTS_CREATE_USER_ERROR';
var OBJECTS_GET_USERS = 'pubnub/OBJECTS_GET_USERS';
var OBJECTS_GET_USERS_ERROR = 'pubnub/OBJECTS_GET_USERS_ERROR';
var OBJECTS_GET_USER_BY_ID = 'pubnub/OBJECTS_GET_USER_BY_ID';
var OBJECTS_GET_USER_BY_ID_ERROR = 'pubnub/OBJECTS_GET_USER_BY_ID_ERROR';
var OBJECTS_FETCH_USERS = 'pubnub/OBJECTS_FETCH_USERS';
var OBJECTS_FETCH_USERS_ERROR = 'pubnub/OBJECTS_FETCH_USERS_ERROR';
var OBJECTS_FETCH_USER_BY_ID = 'pubnub/OBJECTS_FETCH_USER_BY_ID';
var OBJECTS_FETCH_USER_BY_ID_ERROR = 'pubnub/OBJECTS_FETCH_USER_BY_ID_ERROR';
var OBJECTS_CREATE_SPACE = 'pubnub/OBJECTS_CREATE_SPACE';

@@ -38,15 +38,15 @@ var OBJECTS_CREATE_SPACE_BEGIN = 'pubnub/OBJECTS_CREATE_SPACE_BEGIN';

var OBJECTS_DELETE_SPACE_ERROR = 'pubnub/OBJECTS_DELETE_SPACE_ERROR';
var OBJECTS_GET_SPACES = 'pubnub/OBJECTS_GET_SPACES';
var OBJECTS_GET_SPACES_BEGIN = 'pubnub/OBJECTS_GET_SPACES_BEGIN';
var OBJECTS_GET_SPACES_ERROR = 'pubnub/OBJECTS_GET_SPACES_ERROR';
var OBJECTS_GET_SPACE_BY_ID = 'pubnub/OBJECTS_GET_SPACE_BY_ID';
var OBJECTS_GET_SPACE_BY_ID_BEGIN = 'pubnub/OBJECTS_GET_SPACE_BY_ID_BEGIN';
var OBJECTS_GET_SPACE_BY_ID_ERROR = 'pubnub/OBJECTS_GET_SPACE_BY_ID_ERROR';
var OBJECTS_FETCH_SPACES = 'pubnub/OBJECTS_FETCH_SPACES';
var OBJECTS_FETCH_SPACES_BEGIN = 'pubnub/OBJECTS_FETCH_SPACES_BEGIN';
var OBJECTS_FETCH_SPACES_ERROR = 'pubnub/OBJECTS_FETCH_SPACES_ERROR';
var OBJECTS_FETCH_SPACE_BY_ID = 'pubnub/OBJECTS_FETCH_SPACE_BY_ID';
var OBJECTS_FETCH_SPACE_BY_ID_BEGIN = 'pubnub/OBJECTS_FETCH_SPACE_BY_ID_BEGIN';
var OBJECTS_FETCH_SPACE_BY_ID_ERROR = 'pubnub/OBJECTS_FETCH_SPACE_BY_ID_ERROR';
var OBJECTS_USER_ADDED_TO_SPACE = 'pubnub/OBJECTS_USER_ADDED_TO_SPACE';
var OBJECTS_USER_REMOVED_FROM_SPACE = 'pubnub/OBJECTS_USER_REMOVED_FROM_SPACE';
var OBJECTS_USER_MEMBERSHIP_UPDATED_ON_SPACE = 'pubnub/OBJECTS_USER_MEMBERSHIP_UPDATED_ON_SPACE';
var OBJECTS_GET_MEMBERS = 'pubnub/OBJECTS_GET_MEMBERS';
var OBJECTS_GET_MEMBERS_ERROR = 'pubnub/OBJECTS_GET_MEMBERS_ERROR';
var OBJECTS_GET_MEMBERSHIPS = 'pubnub/OBJECTS_GET_MEMBERSHIPS';
var OBJECTS_GET_MEMBERSHIPS_ERROR = 'pubnub/OBJECTS_GET_MEMBERSHIPS_ERROR';
var OBJECTS_FETCH_MEMBERS = 'pubnub/OBJECTS_FETCH_MEMBERS';
var OBJECTS_FETCH_MEMBERS_ERROR = 'pubnub/OBJECTS_FETCH_MEMBERS_ERROR';
var OBJECTS_FETCH_MEMBERSHIPS = 'pubnub/OBJECTS_FETCH_MEMBERSHIPS';
var OBJECTS_FETCH_MEMBERSHIPS_ERROR = 'pubnub/OBJECTS_FETCH_MEMBERSHIPS_ERROR';
var SIGNAL = 'pubnub/SIGNAL';

@@ -366,3 +366,3 @@

return {
type: OBJECTS_GET_USERS,
type: OBJECTS_FETCH_USERS,
payload: payload

@@ -373,15 +373,15 @@ };

return {
type: OBJECTS_GET_USER_BY_ID,
type: OBJECTS_FETCH_USER_BY_ID,
payload: payload
};
};
var getUsersError = function getUsersError(payload) {
var fetchUsersError = function fetchUsersError(payload) {
return {
type: OBJECTS_GET_USERS_ERROR,
type: OBJECTS_FETCH_USERS_ERROR,
payload: payload
};
};
var getUserByIdError = function getUserByIdError(payload) {
var fetchUserByIdError = function fetchUserByIdError(payload) {
return {
type: OBJECTS_GET_USER_BY_ID_ERROR,
type: OBJECTS_FETCH_USER_BY_ID_ERROR,
payload: payload

@@ -410,7 +410,7 @@ };

};
var getUsers = function getUsers(pubnub, options) {
var fetchUsers = function fetchUsers(pubnub, options) {
return function (dispatch) {
pubnub.getUsers(_extends({}, options), function (status, response) {
pubnub.fetchUsers(_extends({}, options), function (status, response) {
if (status.error) {
dispatch(getUsersError(status));
dispatch(fetchUsersError(status));
} else {

@@ -422,3 +422,3 @@ dispatch(userListRetrieved(response.payload));

};
var getUserById = function getUserById(pubnub, userId, include) {
var fetchUserById = function fetchUserById(pubnub, userId, include) {
return function (dispatch) {

@@ -429,3 +429,3 @@ pubnub.getUser(_extends({

if (status.error) {
dispatch(getUserByIdError(status));
dispatch(fetchUserByIdError(status));
} else if (response.data !== undefined) {

@@ -476,14 +476,15 @@ dispatch(userRetrievedById(response.data));

return {
type: OBJECTS_GET_SPACES,
type: OBJECTS_FETCH_SPACES,
payload: payload
};
};
var getSpacesBegin = function getSpacesBegin() {
var fetchSpacesBegin = function fetchSpacesBegin(payload) {
return {
type: OBJECTS_GET_SPACES_BEGIN
type: OBJECTS_FETCH_SPACES_BEGIN,
payload: payload
};
};
var getSpacesError = function getSpacesError(payload) {
var fetchSpacesError = function fetchSpacesError(payload) {
return {
type: OBJECTS_GET_SPACES_ERROR,
type: OBJECTS_FETCH_SPACES_ERROR,
payload: payload

@@ -494,15 +495,15 @@ };

return {
type: OBJECTS_GET_SPACE_BY_ID,
type: OBJECTS_FETCH_SPACE_BY_ID,
payload: payload
};
};
var getSpaceByIdBegin = function getSpaceByIdBegin(payload) {
var fetchSpaceByIdBegin = function fetchSpaceByIdBegin(payload) {
return {
type: OBJECTS_GET_SPACE_BY_ID_BEGIN,
type: OBJECTS_FETCH_SPACE_BY_ID_BEGIN,
payload: payload
};
};
var getSpaceByIdError = function getSpaceByIdError(payload) {
var fetchSpaceByIdError = function fetchSpaceByIdError(payload) {
return {
type: OBJECTS_GET_SPACE_BY_ID_ERROR,
type: OBJECTS_FETCH_SPACE_BY_ID_ERROR,
payload: payload

@@ -544,14 +545,26 @@ };

};
var getSpaces = function getSpaces(pubnub, options) {
var fetchSpaces = function fetchSpaces(pubnub, options, label) {
if (options === void 0) {
options = {};
}
if (label === void 0) {
label = 'all';
}
return function (dispatch) {
dispatch(getSpacesBegin());
dispatch(fetchSpacesBegin({
label: label
}));
pubnub.getSpaces(_extends({}, options), function (status, response) {
if (status.error) {
dispatch(getSpacesError({
dispatch(fetchSpacesError({
code: status.category,
message: status.errorData,
data: response.data
data: response.data,
label: label
}));
} else {
dispatch(spaceListRetrieved({
label: label,
data: response.data.reduce(function (result, value) {

@@ -566,5 +579,5 @@ result[value.id] = value;

};
var getSpaceById = function getSpaceById(pubnub, spaceId, include) {
var fetchSpaceById = function fetchSpaceById(pubnub, spaceId, include) {
return function (dispatch) {
dispatch(getSpaceByIdBegin(spaceId));
dispatch(fetchSpaceByIdBegin(spaceId));
pubnub.getSpace(_extends({

@@ -574,3 +587,3 @@ spaceId: spaceId

if (status.error) {
dispatch(getSpaceByIdError({
dispatch(fetchSpaceByIdError({
code: status.category,

@@ -632,3 +645,3 @@ message: status.errorData,

return {
type: OBJECTS_GET_MEMBERS,
type: OBJECTS_FETCH_MEMBERS,
payload: payload

@@ -640,3 +653,3 @@ };

return {
type: OBJECTS_GET_MEMBERSHIPS,
type: OBJECTS_FETCH_MEMBERSHIPS,
payload: payload

@@ -646,5 +659,5 @@ };

var getMembershipsError = function getMembershipsError(payload) {
var fetchMembershipsError = function fetchMembershipsError(payload) {
return {
type: OBJECTS_GET_MEMBERSHIPS_ERROR,
type: OBJECTS_FETCH_MEMBERSHIPS_ERROR,
payload: payload

@@ -654,5 +667,5 @@ };

var getMembersError = function getMembersError(payload) {
var fetchMembersError = function fetchMembersError(payload) {
return {
type: OBJECTS_GET_MEMBERS_ERROR,
type: OBJECTS_FETCH_MEMBERS_ERROR,
payload: payload

@@ -662,3 +675,3 @@ };

var getMembers = function getMembers(pubnub, spaceId, options) {
var fetchMembers = function fetchMembers(pubnub, spaceId, options) {
return function (dispatch) {

@@ -669,3 +682,3 @@ pubnub.getMembers(_extends({

if (status.error) {
dispatch(getMembersError(status));
dispatch(fetchMembersError(status));
} else {

@@ -677,3 +690,3 @@ dispatch(memberListRetrieved(response));

};
var getMemberships = function getMemberships(pubnub, userId, options) {
var fetchMemberships = function fetchMemberships(pubnub, userId, options) {
return function (dispatch) {

@@ -684,3 +697,3 @@ pubnub.getMemberships(_extends({

if (status.error) {
dispatch(getMembershipsError(status));
dispatch(fetchMembershipsError(status));
} else {

@@ -906,10 +919,10 @@ dispatch(membershipsRetrieved(response));

case OBJECTS_GET_USERS:
case OBJECTS_FETCH_USERS:
return addUsers(state, action);
case OBJECTS_GET_USER_BY_ID:
case OBJECTS_FETCH_USER_BY_ID:
return addUser(state, action);
case OBJECTS_GET_USERS_ERROR:
case OBJECTS_GET_USER_BY_ID_ERROR:
case OBJECTS_FETCH_USERS_ERROR:
case OBJECTS_FETCH_USER_BY_ID_ERROR:
return _extends({}, state, {

@@ -1063,3 +1076,3 @@ error: 'Error while trying to retrieve user(s)'

var beginGetSpaces = function beginGetSpaces(state) {
var beginFetchSpaces = function beginFetchSpaces(state) {
return _extends({}, state, {

@@ -1074,3 +1087,3 @@ data: _extends({}, state.data),

var getSpaces$1 = function getSpaces(state, payload) {
var fetchSpaces$1 = function fetchSpaces(state, payload) {
return _extends({}, state, {

@@ -1084,3 +1097,3 @@ data: _extends({}, payload.data),

var getSpacesError$1 = function getSpacesError(state, payload) {
var fetchSpacesError$1 = function fetchSpacesError(state, payload) {
return _extends({}, state, {

@@ -1094,3 +1107,3 @@ loadingById: _extends({}, state.loadingById),

var beginGetSpaceById = function beginGetSpaceById(state, payload) {
var beginFetchSpaceById = function beginFetchSpaceById(state, payload) {
var newState = _extends({}, state, {

@@ -1109,3 +1122,3 @@ data: _extends({}, state.data),

var getSpaceById$1 = function getSpaceById(state, payload) {
var fetchSpaceById$1 = function fetchSpaceById(state, payload) {
var newState = _extends({}, state, {

@@ -1124,3 +1137,3 @@ data: _extends({}, state.data),

var getSpaceError = function getSpaceError(state, payload) {
var fetchSpaceError = function fetchSpaceError(state, payload) {
var newState = _extends({}, state, {

@@ -1173,26 +1186,20 @@ data: _extends({}, state.data),

case OBJECTS_GET_SPACES_BEGIN:
return beginGetSpaces(state);
case OBJECTS_FETCH_SPACES_BEGIN:
return beginFetchSpaces(state);
case OBJECTS_GET_SPACES:
return getSpaces$1(state, action.payload);
case OBJECTS_FETCH_SPACES:
return fetchSpaces$1(state, action.payload);
case OBJECTS_GET_SPACES_ERROR:
return getSpacesError$1(state, action.payload);
case OBJECTS_FETCH_SPACES_ERROR:
return fetchSpacesError$1(state, action.payload);
case OBJECTS_GET_SPACE_BY_ID_BEGIN:
return beginGetSpaceById(state, action.payload);
case OBJECTS_FETCH_SPACE_BY_ID_BEGIN:
return beginFetchSpaceById(state, action.payload);
case OBJECTS_GET_SPACE_BY_ID:
return getSpaceById$1(state, action.payload);
case OBJECTS_FETCH_SPACE_BY_ID:
return fetchSpaceById$1(state, action.payload);
case OBJECTS_GET_SPACE_BY_ID_ERROR:
return getSpaceError(state, action.payload);
case OBJECTS_FETCH_SPACE_BY_ID_ERROR:
return fetchSpaceError(state, action.payload);
case OBJECTS_UPDATE_SPACE:
return updateSpace(state, action.payload);
case OBJECTS_UPDATE_SPACE_ERROR:
return updateSpaceError(state, action.payload);
default:

@@ -1204,2 +1211,67 @@ return state;

var createInitialState$1 = function createInitialState() {
return {
data: [],
loading: false,
error: undefined
};
};
var beginFetchSpaces$1 = function beginFetchSpaces(state) {
return {
data: [].concat(state.data),
loading: true,
error: undefined
};
};
var fetchSpaces$2 = function fetchSpaces(payload) {
var data = Object.keys(payload.data).map(function (key) {
return payload.data[key].id;
});
return {
data: data,
loading: false,
error: undefined
};
};
var fetchSpacesError$2 = function fetchSpacesError(state, payload) {
return {
data: [].concat(state.data),
loading: false,
error: payload
};
};
var createSpaceListReducer = function createSpaceListReducer(label) {
if (label === void 0) {
label = 'all';
}
return function (state, action) {
if (state === void 0) {
state = createInitialState$1();
}
if (action.payload !== undefined && action.payload.label === label) {
switch (action.type) {
case OBJECTS_FETCH_SPACES_BEGIN:
return beginFetchSpaces$1(state);
case OBJECTS_FETCH_SPACES:
return fetchSpaces$2(action.payload);
case OBJECTS_FETCH_SPACES_ERROR:
return fetchSpacesError$2(state, action.payload);
default:
return state;
}
} else {
return state;
}
};
};
var initialState$1 = {

@@ -1252,3 +1324,3 @@ usersById: {

var getMembers$1 = function getMembers(state, payload) {
var fetchMembers$1 = function fetchMembers(state, payload) {
var receivedUsers = initialState$1;

@@ -1271,3 +1343,3 @@

var getMembeberships = function getMembeberships(state, payload) {
var fetchMembeberships = function fetchMembeberships(state, payload) {
var receivedSpaces = initialState$1;

@@ -1290,3 +1362,3 @@

var getMemberError = function getMemberError(state, payload) {
var fetchMemberError = function fetchMemberError(state, payload) {
return _extends({}, state, {

@@ -1312,11 +1384,11 @@ error: payload.errorData !== undefined ? payload.errorData.error.message : payload.message

case OBJECTS_GET_MEMBERS:
return getMembers$1(state, action.payload);
case OBJECTS_FETCH_MEMBERS:
return fetchMembers$1(state, action.payload);
case OBJECTS_GET_MEMBERSHIPS:
return getMembeberships(state, action.payload);
case OBJECTS_FETCH_MEMBERSHIPS:
return fetchMembeberships(state, action.payload);
case OBJECTS_GET_MEMBERSHIPS_ERROR:
case OBJECTS_GET_MEMBERS_ERROR:
return getMemberError(state, action.payload);
case OBJECTS_FETCH_MEMBERSHIPS_ERROR:
case OBJECTS_FETCH_MEMBERS_ERROR:
return fetchMemberError(state, action.payload);

@@ -1342,2 +1414,3 @@ default:

exports.createSpaceActionListener = createSpaceActionListener;
exports.createSpaceListReducer = createSpaceListReducer;
exports.createSpaceReducer = createSpaceReducer;

@@ -1348,10 +1421,10 @@ exports.createSubscribeStatusActionListener = createSubscribeStatusActionListener;

exports.decryptionError = decryptionError;
exports.getMembers = getMembers;
exports.getMemberships = getMemberships;
exports.getSpaceById = getSpaceById;
exports.getSpaces = getSpaces;
exports.getSpacesError = getSpacesError;
exports.getUserById = getUserById;
exports.getUsers = getUsers;
exports.getUsersError = getUsersError;
exports.fetchMembers = fetchMembers;
exports.fetchMemberships = fetchMemberships;
exports.fetchSpaceById = fetchSpaceById;
exports.fetchSpaces = fetchSpaces;
exports.fetchSpacesError = fetchSpacesError;
exports.fetchUserById = fetchUserById;
exports.fetchUsers = fetchUsers;
exports.fetchUsersError = fetchUsersError;
exports.malformedResponse = malformedResponse;

@@ -1358,0 +1431,0 @@ exports.membershipReducer = membershipReducer;

2

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

@@ -1,2 +0,2 @@

"use strict";var e=function(e){return{type:"pubnub/JOIN",payload:e}},r=function(e){return{type:"pubnub/LEAVE",payload:e}},a=function(e){return{type:"pubnub/TIMEOUT",payload:e}},t=function(e){return{type:"pubnub/STATE_CHANGE",payload:e}},n=function(n){return{presence:function(o){switch(o.action){case"join":n(e(o));break;case"leave":n(r(o));break;case"timeout":n(a(o));break;case"state-change":n(t(o))}}}},o=function(e){return{status:function(r){switch(r.category){case"PNNetworkUpCategory":e({type:"pubnub/NETWORK_UP"});break;case"PNNetworkDownCategory":case"PNNetworkIssuesCategory":e({type:"pubnub/NETWORK_DOWN"});break;case"PNReconnectedCategory":case"PNConnectedCategory":e({type:"pubnub/NETWORK_UP"});break;case"PNTimeoutCategory":e({type:"pubnub/NETWORK_DOWN"})}}}},d=function(e){return{type:"pubnub/RECONNECTED",payload:e}},u=function(e){return{type:"pubnub/CONNECTED",payload:e}},i=function(e){return{status:function(r){switch(r.category){case"PNReconnectedCategory":e(d(r));break;case"PNConnectedCategory":e(u(r))}}}},s=function(e){return{type:"pubnub/NETWORK_ISSUES",payload:e}},p=function(e){return{type:"pubnub/ACCESS_DENIED",payload:e}},c=function(e){return{type:"pubnub/MALFORMED_RESPONSE",payload:e}},y=function(e){return{type:"pubnub/BAD_REQUEST",payload:e}},E=function(e){return{type:"pubnub/DECRYPTION_ERROR",payload:e}},l=function(e){return{type:"pubnub/TIMEOUT_CONNECTION",payload:e}},b=function(e){return{type:"pubnub/REQUEST_MESSAGE_COUNT_EXCEED",payload:e}},B=function(e){return{type:"pubnub/UNKNOWN",payload:e}},I=function(e){return{status:function(r){switch(r.category){case"PNNetworkIssuesCategory":e(s(r));break;case"PNAccessDeniedCategory":e(p(r));break;case"PNMalformedResponseCategory":e(c(r));break;case"PNBadRequestCategory":e(y(r));break;case"PNDecryptionErrorCategory":e(E(r));break;case"PNTimeoutCategory":e(l(r));break;case"PNRequestMessageCountExceedCategory":e(b(r));break;case"PNUnknownCategory":e(B(r))}}}},_=function(e){return{message:function(r){return e({type:"pubnub/MESSAGE",payload:r})}}},S=function(e){return{signal:function(r){return e({type:"pubnub/SIGNAL",payload:r})}}};function f(){return(f=Object.assign||function(e){for(var r=1;r<arguments.length;r++){var a=arguments[r];for(var t in a)Object.prototype.hasOwnProperty.call(a,t)&&(e[t]=a[t])}return e}).apply(this,arguments)}function g(e){var r=function(e,r){if("object"!=typeof e||null===e)return e;var a=e[Symbol.toPrimitive];if(void 0!==a){var t=a.call(e,"string");if("object"!=typeof t)return t;throw new TypeError("@@toPrimitive must return a primitive value.")}return String(e)}(e);return"symbol"==typeof r?r:String(r)}var T=function(e){return{type:"pubnub/OBJECTS_UPDATE_USER",payload:e}},C=function(e){return{type:"pubnub/OBJECTS_DELETE_USER",payload:e}},R=function(e){return{type:"pubnub/OBJECTS_GET_USERS",payload:e}},O=function(e){return{type:"pubnub/OBJECTS_GET_USERS_ERROR",payload:e}},A=function(e){return{user:function(r){switch(r.event){case"update":e(T(r.data));break;case"delete":e(C(r.data))}}}},v=function(e){return{type:"pubnub/OBJECTS_GET_SPACES",payload:e}},P=function(e){return{type:"pubnub/OBJECTS_GET_SPACES_ERROR",payload:e}},N=function(e){return{type:"pubnub/OBJECTS_UPDATE_SPACE",payload:e}},D=function(e){return{type:"pubnub/OBJECTS_DELETE_SPACE",payload:e}},J=function(e){return{space:function(r){switch(r.message.event){case"update":e(N({data:r.message.data}));break;case"delete":e(D({data:r.message.data}))}}}},U=function(e){return{type:"pubnub/OBJECTS_USER_MEMBERSHIP_UPDATED_ON_SPACE",payload:e}},x=function(e){return{type:"pubnub/OBJECTS_USER_ADDED_TO_SPACE",payload:e}},m=function(e){return{type:"pubnub/OBJECTS_USER_REMOVED_FROM_SPACE",payload:e}},h=function(e){return{membership:function(r){switch(r.message.event){case"create":e(x(r));break;case"update":e(U(r));break;case"delete":e(m(r))}}}},G=function(){for(var e=arguments.length,r=new Array(e),a=0;a<e;a++)r[a]=arguments[a];return Object.assign.apply(Object,[{}].concat(M(r)))},M=function(e){var r=[],a={};return e.forEach(function(e){var r=Object.keys(e)[0];a.hasOwnProperty(r)||(a[r]=[]),a[r].push(e)}),Object.entries(a).forEach(function(e){var a=e[0],t=e[1];1===t.length?r.push(t[0]):t.length>1&&r.push(w(a,t))}),r},w=function(e,r){var a;return(a={})[e]=function(a){r.forEach(function(r){return r[e](a)})},a},k={},L=function(e,r){var a=f({},e,{data:f({},e.data),loadingById:f({},e.loadingById),errorById:f({},e.errorById)}),t=r.data.id,n=void 0!==a.loadingById[t]?a.loadingById[t]:0;return a.data[t]=f({},r.data),a.loadingById[t]=n>0?n-1:0,a},W=function(e,r){var a=f({},e,{data:f({},e.data),loadingById:f({},e.loadingById),errorById:f({},e.errorById)}),t=r.data.id,n=void 0!==a.loadingById[t]?a.loadingById[t]:0;return a.loadingById[t]=n>0?n-1:0,a.errorById[t]=r,a},Y={usersById:{byId:{},allIds:[]},spacesById:{byId:{},allIds:[]},error:"",space:{}};exports.accessDenied=p,exports.badRequest=y,exports.combineListeners=G,exports.connected=u,exports.createErrorStatusActionListener=I,exports.createMembershipActionListener=h,exports.createMessageActionListener=_,exports.createNetworkStatusActionListener=o,exports.createNetworkStatusReducer=function(e){var r;if("boolean"==typeof e)r={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(r={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=r),a.type){case"pubnub/NETWORK_UP":return f({},e,{isConnected:!0});case"pubnub/NETWORK_DOWN":return f({},e,{isConnected:!1});default:return e}}},exports.createPresenceActionListener=n,exports.createPubNubActionListener=function(e){return G(_(e),n(e),S(e),A(e),J(e),h(e),o(e),i(e),I(e))},exports.createSignalActionListener=S,exports.createSpace=function(e,r,a,t){return function(n){n({type:"pubnub/OBJECTS_CREATE_SPACE_BEGIN",payload:t}),e.createSpace(f({id:r,name:a},t),function(e,r){n(e.error?{type:"pubnub/OBJECTS_CREATE_SPACE_ERROR",payload:{code:e.category,message:e.errorData,data:r.data}}:{type:"pubnub/OBJECTS_CREATE_SPACE",payload:{data:r.data}})})}},exports.createSpaceActionListener=J,exports.createSpaceReducer=function(){return function(e,r){switch(void 0===e&&(e={data:{},loadingAll:0,loadingById:{},errorAll:void 0,errorById:{}}),r.type){case"pubnub/OBJECTS_CREATE_SPACE_BEGIN":return function(e,r){var a=f({},e,{data:f({},e.data),loadingById:f({},e.loadingById),errorById:f({},e.errorById)}),t=r.id;return a.loadingById[t]=(void 0!==a.loadingById[t]?a.loadingById[t]:0)+1,delete a.errorById[t],a}(e,r.payload);case"pubnub/OBJECTS_CREATE_SPACE":return function(e,r){var a=f({},e,{data:f({},e.data),loadingById:f({},e.loadingById),errorById:f({},e.errorById)}),t=r.data.id,n=void 0!==a.loadingById[t]?a.loadingById[t]:0;return a.data[t]=f({},r.data),a.loadingById[t]=n>0?n-1:0,a}(e,r.payload);case"pubnub/OBJECTS_CREATE_SPACE_ERROR":return function(e,r){var a=f({},e,{data:f({},e.data),loadingById:f({},e.loadingById),errorById:f({},e.errorById)}),t=r.data.id,n=void 0!==a.loadingById[t]?a.loadingById[t]:0;return a.loadingById[t]=n>0?n-1:0,a.errorById[t]=r,a}(e,r.payload);case"pubnub/OBJECTS_UPDATE_SPACE_BEGIN":return function(e,r){var a=f({},e,{data:f({},e.data),loadingById:f({},e.loadingById),errorById:f({},e.errorById)}),t=r.id;return a.loadingById[t]=(void 0!==a.loadingById[t]?a.loadingById[t]:0)+1,delete a.errorById[t],a}(e,r.payload);case"pubnub/OBJECTS_UPDATE_SPACE":return L(e,r.payload);case"pubnub/OBJECTS_UPDATE_SPACE_ERROR":return W(e,r.payload);case"pubnub/OBJECTS_DELETE_SPACE_BEGIN":return function(e,r){var a=f({},e,{data:f({},e.data),loadingById:f({},e.loadingById),errorById:f({},e.errorById)}),t=r;return a.loadingById[t]=(void 0!==a.loadingById[t]?a.loadingById[t]:0)+1,delete a.errorById[t],a}(e,r.payload);case"pubnub/OBJECTS_DELETE_SPACE":return function(e,r){var a=f({},e,{data:f({},e.data),loadingById:f({},e.loadingById),errorById:f({},e.errorById)}),t=r.data.id,n=void 0!==a.loadingById[t]?a.loadingById[t]:0;return a.loadingById[t]=n>0?n-1:0,delete a.data[t],a}(e,r.payload);case"pubnub/OBJECTS_DELETE_SPACE_ERROR":return function(e,r){var a=f({},e,{data:f({},e.data),loadingById:f({},e.loadingById),errorById:f({},e.errorById)}),t=r.data.id,n=void 0!==a.loadingById[t]?a.loadingById[t]:0;return a.loadingById[t]=n>0?n-1:0,a.errorById[t]=r,a}(e,r.payload);case"pubnub/OBJECTS_GET_SPACES_BEGIN":return function(e){return f({},e,{data:f({},e.data),loadingById:f({},e.loadingById),errorById:f({},e.errorById),loadingAll:e.loadingAll+1,errorAll:void 0})}(e);case"pubnub/OBJECTS_GET_SPACES":return function(e,a){return f({},e,{data:f({},r.payload.data),loadingById:f({},e.loadingById),errorById:f({},e.errorById),loadingAll:void 0!==e.loadingAll?e.loadingAll-1:0})}(e);case"pubnub/OBJECTS_GET_SPACES_ERROR":return function(e,r){return f({},e,{loadingById:f({},e.loadingById),errorById:f({},e.errorById),loadingAll:void 0!==e.loadingAll?e.loadingAll-1:0,error:r})}(e,r.payload);case"pubnub/OBJECTS_GET_SPACE_BY_ID_BEGIN":return function(e,r){var a=f({},e,{data:f({},e.data),loadingById:f({},e.loadingById),errorById:f({},e.errorById)}),t=r;return a.loadingById[t]=(void 0!==a.loadingById[t]?a.loadingById[t]:0)+1,delete a.errorById[t],a}(e,r.payload);case"pubnub/OBJECTS_GET_SPACE_BY_ID":return function(e,r){var a=f({},e,{data:f({},e.data),loadingById:f({},e.loadingById),errorById:f({},e.errorById)}),t=r.data.id,n=void 0!==a.loadingById[t]?a.loadingById[t]:0;return a.data[t]=f({},r.data),a.loadingById[t]=n>0?n-1:0,a}(e,r.payload);case"pubnub/OBJECTS_GET_SPACE_BY_ID_ERROR":return function(e,r){var a=f({},e,{data:f({},e.data),loadingById:f({},e.loadingById),errorById:f({},e.errorById)}),t=r.data.id,n=void 0!==a.loadingById[t]?a.loadingById[t]:0;return a.loadingById[t]=n>0?n-1:0,a.errorById[t]=r,a}(e,r.payload);case"pubnub/OBJECTS_UPDATE_SPACE":return L(e,r.payload);case"pubnub/OBJECTS_UPDATE_SPACE_ERROR":return W(e,r.payload);default:return e}}},exports.createSubscribeStatusActionListener=i,exports.createUser=function(e,r,a,t){return function(n){e.createUser(f({id:r,name:a},t),function(e,r){e.error?n({type:"pubnub/OBJECTS_CREATE_USER_ERROR",payload:e}):void 0!==r.data&&n({type:"pubnub/OBJECTS_CREATE_USER",payload:r.data})})}},exports.createUserActionListener=A,exports.decryptionError=E,exports.getMembers=function(e,r,a){return function(t){e.getMembers(f({spaceId:r},a),function(e,r){t(e.error?{type:"pubnub/OBJECTS_GET_MEMBERS_ERROR",payload:e}:{type:"pubnub/OBJECTS_GET_MEMBERS",payload:r})})}},exports.getMemberships=function(e,r,a){return function(t){e.getMemberships(f({userId:r},a),function(e,r){t(e.error?{type:"pubnub/OBJECTS_GET_MEMBERSHIPS_ERROR",payload:e}:{type:"pubnub/OBJECTS_GET_MEMBERSHIPS",payload:r})})}},exports.getSpaceById=function(e,r,a){return function(t){t({type:"pubnub/OBJECTS_GET_SPACE_BY_ID_BEGIN",payload:r}),e.getSpace(f({spaceId:r},a),function(e,r){t(e.error?{type:"pubnub/OBJECTS_GET_SPACE_BY_ID_ERROR",payload:{code:e.category,message:e.errorData,data:r.data}}:{type:"pubnub/OBJECTS_GET_SPACE_BY_ID",payload:{data:r.data}})})}},exports.getSpaces=function(e,r){return function(a){a({type:"pubnub/OBJECTS_GET_SPACES_BEGIN"}),e.getSpaces(f({},r),function(e,r){a(e.error?P({code:e.category,message:e.errorData,data:r.data}):v({data:r.data.reduce(function(e,r){return e[r.id]=r,e},{})}))})}},exports.getSpacesError=P,exports.getUserById=function(e,r,a){return function(t){e.getUser(f({userId:r},a),function(e,r){e.error?t({type:"pubnub/OBJECTS_GET_USER_BY_ID_ERROR",payload:e}):void 0!==r.data&&t({type:"pubnub/OBJECTS_GET_USER_BY_ID",payload:r.data})})}},exports.getUsers=function(e,r){return function(a){e.getUsers(f({},r),function(e,r){a(e.error?O(e):R(r.payload))})}},exports.getUsersError=O,exports.malformedResponse=c,exports.membershipReducer=function(e,r){switch(void 0===e&&(e=Y),r.type){case"pubnub/OBJECTS_USER_ADDED_TO_SPACE":return function(e,r){var a;return"id"in r.message.data?f({},e,{usersById:f({},e.usersById,{byId:f({},e.usersById.byId,(a={},a[r.message.data.id]=r.message.data,a)),allIds:[].concat(e.usersById.allIds,[r.message.data.id])})}):e}(e,r.payload);case"pubnub/OBJECTS_USER_REMOVED_FROM_SPACE":return function(e,r){var a=function(e,r){if(null==e)return{};var a,t,n={},o=Object.keys(e);for(t=0;t<o.length;t++)r.indexOf(a=o[t])>=0||(n[a]=e[a]);return n}(e.usersById.byId,[r.message.data.id].map(g));return f({},e,{usersById:f({},e.usersById,{byId:a,allIds:e.usersById.allIds.filter(function(e){return e!==r.message.data.id})})})}(e,r.payload);case"pubnub/OBJECTS_USER_MEMBERSHIP_UPDATED_ON_SPACE":return function(e,a){return f({},e,{user:r.payload.message.data})}(e);case"pubnub/OBJECTS_GET_MEMBERS":return function(e,r){var a=Y;return Array.isArray(r.data)&&r.data.forEach(function(e){a.usersById.byId[e.id]=e,a.usersById.allIds=a.usersById.allIds.concat(e.id)}),f({},e,{spacesById:f({},e.usersById,{byId:a.usersById.byId,allIds:a.usersById.allIds})})}(e,r.payload);case"pubnub/OBJECTS_GET_MEMBERSHIPS":return function(e,r){var a=Y;return Array.isArray(r.data)&&r.data.forEach(function(e){a.spacesById.byId[e.id]=e,a.spacesById.allIds=a.spacesById.allIds.concat(e.id)}),f({},e,{spacesById:f({},e.spacesById,{byId:a.spacesById.byId,allIds:a.spacesById.allIds})})}(e,r.payload);case"pubnub/OBJECTS_GET_MEMBERSHIPS_ERROR":case"pubnub/OBJECTS_GET_MEMBERS_ERROR":return function(e,r){return f({},e,{error:void 0!==r.errorData?r.errorData.error.message:r.message})}(e,r.payload);default:return e}},exports.networkDown=function(){return{type:"pubnub/NETWORK_DOWN"}},exports.networkIssues=s,exports.networkUp=function(){return{type:"pubnub/NETWORK_UP"}},exports.reconnected=d,exports.requestMessageCountExceed=b,exports.spaceDeleted=D,exports.spaceListRetrieved=v,exports.spaceUpdated=N,exports.timeoutConnection=l,exports.unknown=B,exports.userAddedToSpace=x,exports.userDeleted=C,exports.userJoin=e,exports.userLeave=r,exports.userListRetrieved=R,exports.userMembershipUpdatedOnSpace=U,exports.userReducer=function(e,r){switch(void 0===e&&(e=k),r.type){case"pubnub/OBJECTS_CREATE_USER":return function(e,r){void 0===e&&(e=k);var a=f({},e);return a[r.payload.id]=r.payload,a}(e,r);case"pubnub/OBJECTS_CREATE_USER_ERROR":return f({},e,{error:"Error while trying to create an user"});case"pubnub/OBJECTS_DELETE_USER":return function(e,r){void 0===e&&(e=k);var a=f({},e);return delete a[r.payload.id],a}(e,r);case"pubnub/OBJECTS_GET_USERS":return function(e,r){void 0===e&&(e=k);var a=f({},e);return r.payload.forEach(function(e){a[e.id]=e}),a}(e,r);case"pubnub/OBJECTS_GET_USER_BY_ID":return function(e,r){void 0===e&&(e=k);var a=f({},e);return a[r.payload.id]=r.payload,a}(e,r);case"pubnub/OBJECTS_GET_USERS_ERROR":case"pubnub/OBJECTS_GET_USER_BY_ID_ERROR":return f({},e,{error:"Error while trying to retrieve user(s)"});case"pubnub/OBJECTS_UPDATE_USER":return function(e,r){void 0===e&&(e=k);var a=f({},e);return a[r.payload.id]=r.payload,a}(e,r);default:return e}},exports.userRemovedFromSpace=m,exports.userStateChange=t,exports.userTimeout=a,exports.userUpdated=T;
"use strict";var e=function(e){return{type:"pubnub/JOIN",payload:e}},r=function(e){return{type:"pubnub/LEAVE",payload:e}},a=function(e){return{type:"pubnub/TIMEOUT",payload:e}},t=function(e){return{type:"pubnub/STATE_CHANGE",payload:e}},n=function(n){return{presence:function(o){switch(o.action){case"join":n(e(o));break;case"leave":n(r(o));break;case"timeout":n(a(o));break;case"state-change":n(t(o))}}}},o=function(e){return{status:function(r){switch(r.category){case"PNNetworkUpCategory":e({type:"pubnub/NETWORK_UP"});break;case"PNNetworkDownCategory":case"PNNetworkIssuesCategory":e({type:"pubnub/NETWORK_DOWN"});break;case"PNReconnectedCategory":case"PNConnectedCategory":e({type:"pubnub/NETWORK_UP"});break;case"PNTimeoutCategory":e({type:"pubnub/NETWORK_DOWN"})}}}},d=function(e){return{type:"pubnub/RECONNECTED",payload:e}},u=function(e){return{type:"pubnub/CONNECTED",payload:e}},i=function(e){return{status:function(r){switch(r.category){case"PNReconnectedCategory":e(d(r));break;case"PNConnectedCategory":e(u(r))}}}},s=function(e){return{type:"pubnub/NETWORK_ISSUES",payload:e}},c=function(e){return{type:"pubnub/ACCESS_DENIED",payload:e}},p=function(e){return{type:"pubnub/MALFORMED_RESPONSE",payload:e}},y=function(e){return{type:"pubnub/BAD_REQUEST",payload:e}},E=function(e){return{type:"pubnub/DECRYPTION_ERROR",payload:e}},l=function(e){return{type:"pubnub/TIMEOUT_CONNECTION",payload:e}},b=function(e){return{type:"pubnub/REQUEST_MESSAGE_COUNT_EXCEED",payload:e}},B=function(e){return{type:"pubnub/UNKNOWN",payload:e}},I=function(e){return{status:function(r){switch(r.category){case"PNNetworkIssuesCategory":e(s(r));break;case"PNAccessDeniedCategory":e(c(r));break;case"PNMalformedResponseCategory":e(p(r));break;case"PNBadRequestCategory":e(y(r));break;case"PNDecryptionErrorCategory":e(E(r));break;case"PNTimeoutCategory":e(l(r));break;case"PNRequestMessageCountExceedCategory":e(b(r));break;case"PNUnknownCategory":e(B(r))}}}},_=function(e){return{message:function(r){return e({type:"pubnub/MESSAGE",payload:r})}}},S=function(e){return{signal:function(r){return e({type:"pubnub/SIGNAL",payload:r})}}};function C(){return(C=Object.assign||function(e){for(var r=1;r<arguments.length;r++){var a=arguments[r];for(var t in a)Object.prototype.hasOwnProperty.call(a,t)&&(e[t]=a[t])}return e}).apply(this,arguments)}function f(e){var r=function(e,r){if("object"!=typeof e||null===e)return e;var a=e[Symbol.toPrimitive];if(void 0!==a){var t=a.call(e,"string");if("object"!=typeof t)return t;throw new TypeError("@@toPrimitive must return a primitive value.")}return String(e)}(e);return"symbol"==typeof r?r:String(r)}var T=function(e){return{type:"pubnub/OBJECTS_UPDATE_USER",payload:e}},g=function(e){return{type:"pubnub/OBJECTS_DELETE_USER",payload:e}},R=function(e){return{type:"pubnub/OBJECTS_FETCH_USERS",payload:e}},O=function(e){return{type:"pubnub/OBJECTS_FETCH_USERS_ERROR",payload:e}},A=function(e){return{user:function(r){switch(r.event){case"update":e(T(r.data));break;case"delete":e(g(r.data))}}}},v=function(e){return{type:"pubnub/OBJECTS_FETCH_SPACES",payload:e}},P=function(e){return{type:"pubnub/OBJECTS_FETCH_SPACES_ERROR",payload:e}},N=function(e){return{type:"pubnub/OBJECTS_UPDATE_SPACE",payload:e}},J=function(e){return{type:"pubnub/OBJECTS_DELETE_SPACE",payload:e}},D=function(e){return{space:function(r){switch(r.message.event){case"update":e(N({data:r.message.data}));break;case"delete":e(J({data:r.message.data}))}}}},U=function(e){return{type:"pubnub/OBJECTS_USER_MEMBERSHIP_UPDATED_ON_SPACE",payload:e}},x=function(e){return{type:"pubnub/OBJECTS_USER_ADDED_TO_SPACE",payload:e}},h=function(e){return{type:"pubnub/OBJECTS_USER_REMOVED_FROM_SPACE",payload:e}},m=function(e){return{membership:function(r){switch(r.message.event){case"create":e(x(r));break;case"update":e(U(r));break;case"delete":e(h(r))}}}},M=function(){for(var e=arguments.length,r=new Array(e),a=0;a<e;a++)r[a]=arguments[a];return Object.assign.apply(Object,[{}].concat(H(r)))},H=function(e){var r=[],a={};return e.forEach(function(e){var r=Object.keys(e)[0];a.hasOwnProperty(r)||(a[r]=[]),a[r].push(e)}),Object.entries(a).forEach(function(e){var a=e[0],t=e[1];1===t.length?r.push(t[0]):t.length>1&&r.push(w(a,t))}),r},w=function(e,r){var a;return(a={})[e]=function(a){r.forEach(function(r){return r[e](a)})},a},F={},k={usersById:{byId:{},allIds:[]},spacesById:{byId:{},allIds:[]},error:"",space:{}};exports.accessDenied=c,exports.badRequest=y,exports.combineListeners=M,exports.connected=u,exports.createErrorStatusActionListener=I,exports.createMembershipActionListener=m,exports.createMessageActionListener=_,exports.createNetworkStatusActionListener=o,exports.createNetworkStatusReducer=function(e){var r;if("boolean"==typeof e)r={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(r={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=r),a.type){case"pubnub/NETWORK_UP":return C({},e,{isConnected:!0});case"pubnub/NETWORK_DOWN":return C({},e,{isConnected:!1});default:return e}}},exports.createPresenceActionListener=n,exports.createPubNubActionListener=function(e){return M(_(e),n(e),S(e),A(e),D(e),m(e),o(e),i(e),I(e))},exports.createSignalActionListener=S,exports.createSpace=function(e,r,a,t){return function(n){n({type:"pubnub/OBJECTS_CREATE_SPACE_BEGIN",payload:t}),e.createSpace(C({id:r,name:a},t),function(e,r){n(e.error?{type:"pubnub/OBJECTS_CREATE_SPACE_ERROR",payload:{code:e.category,message:e.errorData,data:r.data}}:{type:"pubnub/OBJECTS_CREATE_SPACE",payload:{data:r.data}})})}},exports.createSpaceActionListener=D,exports.createSpaceListReducer=function(e){return void 0===e&&(e="all"),function(r,a){if(void 0===r&&(r={data:[],loading:!1,error:void 0}),void 0===a.payload||a.payload.label!==e)return r;switch(a.type){case"pubnub/OBJECTS_FETCH_SPACES_BEGIN":return function(e){return{data:[].concat(e.data),loading:!0,error:void 0}}(r);case"pubnub/OBJECTS_FETCH_SPACES":return t=a.payload,{data:Object.keys(t.data).map(function(e){return t.data[e].id}),loading:!1,error:void 0};case"pubnub/OBJECTS_FETCH_SPACES_ERROR":return function(e,r){return{data:[].concat(e.data),loading:!1,error:r}}(r,a.payload);default:return r}var t}},exports.createSpaceReducer=function(){return function(e,r){switch(void 0===e&&(e={data:{},loadingAll:0,loadingById:{},errorAll:void 0,errorById:{}}),r.type){case"pubnub/OBJECTS_CREATE_SPACE_BEGIN":return function(e,r){var a=C({},e,{data:C({},e.data),loadingById:C({},e.loadingById),errorById:C({},e.errorById)}),t=r.id;return a.loadingById[t]=(void 0!==a.loadingById[t]?a.loadingById[t]:0)+1,delete a.errorById[t],a}(e,r.payload);case"pubnub/OBJECTS_CREATE_SPACE":return function(e,r){var a=C({},e,{data:C({},e.data),loadingById:C({},e.loadingById),errorById:C({},e.errorById)}),t=r.data.id,n=void 0!==a.loadingById[t]?a.loadingById[t]:0;return a.data[t]=C({},r.data),a.loadingById[t]=n>0?n-1:0,a}(e,r.payload);case"pubnub/OBJECTS_CREATE_SPACE_ERROR":return function(e,r){var a=C({},e,{data:C({},e.data),loadingById:C({},e.loadingById),errorById:C({},e.errorById)}),t=r.data.id,n=void 0!==a.loadingById[t]?a.loadingById[t]:0;return a.loadingById[t]=n>0?n-1:0,a.errorById[t]=r,a}(e,r.payload);case"pubnub/OBJECTS_UPDATE_SPACE_BEGIN":return function(e,r){var a=C({},e,{data:C({},e.data),loadingById:C({},e.loadingById),errorById:C({},e.errorById)}),t=r.id;return a.loadingById[t]=(void 0!==a.loadingById[t]?a.loadingById[t]:0)+1,delete a.errorById[t],a}(e,r.payload);case"pubnub/OBJECTS_UPDATE_SPACE":return function(e,r){var a=C({},e,{data:C({},e.data),loadingById:C({},e.loadingById),errorById:C({},e.errorById)}),t=r.data.id,n=void 0!==a.loadingById[t]?a.loadingById[t]:0;return a.data[t]=C({},r.data),a.loadingById[t]=n>0?n-1:0,a}(e,r.payload);case"pubnub/OBJECTS_UPDATE_SPACE_ERROR":return function(e,r){var a=C({},e,{data:C({},e.data),loadingById:C({},e.loadingById),errorById:C({},e.errorById)}),t=r.data.id,n=void 0!==a.loadingById[t]?a.loadingById[t]:0;return a.loadingById[t]=n>0?n-1:0,a.errorById[t]=r,a}(e,r.payload);case"pubnub/OBJECTS_DELETE_SPACE_BEGIN":return function(e,r){var a=C({},e,{data:C({},e.data),loadingById:C({},e.loadingById),errorById:C({},e.errorById)}),t=r;return a.loadingById[t]=(void 0!==a.loadingById[t]?a.loadingById[t]:0)+1,delete a.errorById[t],a}(e,r.payload);case"pubnub/OBJECTS_DELETE_SPACE":return function(e,r){var a=C({},e,{data:C({},e.data),loadingById:C({},e.loadingById),errorById:C({},e.errorById)}),t=r.data.id,n=void 0!==a.loadingById[t]?a.loadingById[t]:0;return a.loadingById[t]=n>0?n-1:0,delete a.data[t],a}(e,r.payload);case"pubnub/OBJECTS_DELETE_SPACE_ERROR":return function(e,r){var a=C({},e,{data:C({},e.data),loadingById:C({},e.loadingById),errorById:C({},e.errorById)}),t=r.data.id,n=void 0!==a.loadingById[t]?a.loadingById[t]:0;return a.loadingById[t]=n>0?n-1:0,a.errorById[t]=r,a}(e,r.payload);case"pubnub/OBJECTS_FETCH_SPACES_BEGIN":return function(e){return C({},e,{data:C({},e.data),loadingById:C({},e.loadingById),errorById:C({},e.errorById),loadingAll:e.loadingAll+1,errorAll:void 0})}(e);case"pubnub/OBJECTS_FETCH_SPACES":return function(e,a){return C({},e,{data:C({},r.payload.data),loadingById:C({},e.loadingById),errorById:C({},e.errorById),loadingAll:void 0!==e.loadingAll?e.loadingAll-1:0})}(e);case"pubnub/OBJECTS_FETCH_SPACES_ERROR":return function(e,r){return C({},e,{loadingById:C({},e.loadingById),errorById:C({},e.errorById),loadingAll:void 0!==e.loadingAll?e.loadingAll-1:0,error:r})}(e,r.payload);case"pubnub/OBJECTS_FETCH_SPACE_BY_ID_BEGIN":return function(e,r){var a=C({},e,{data:C({},e.data),loadingById:C({},e.loadingById),errorById:C({},e.errorById)}),t=r;return a.loadingById[t]=(void 0!==a.loadingById[t]?a.loadingById[t]:0)+1,delete a.errorById[t],a}(e,r.payload);case"pubnub/OBJECTS_FETCH_SPACE_BY_ID":return function(e,r){var a=C({},e,{data:C({},e.data),loadingById:C({},e.loadingById),errorById:C({},e.errorById)}),t=r.data.id,n=void 0!==a.loadingById[t]?a.loadingById[t]:0;return a.data[t]=C({},r.data),a.loadingById[t]=n>0?n-1:0,a}(e,r.payload);case"pubnub/OBJECTS_FETCH_SPACE_BY_ID_ERROR":return function(e,r){var a=C({},e,{data:C({},e.data),loadingById:C({},e.loadingById),errorById:C({},e.errorById)}),t=r.data.id,n=void 0!==a.loadingById[t]?a.loadingById[t]:0;return a.loadingById[t]=n>0?n-1:0,a.errorById[t]=r,a}(e,r.payload);default:return e}}},exports.createSubscribeStatusActionListener=i,exports.createUser=function(e,r,a,t){return function(n){e.createUser(C({id:r,name:a},t),function(e,r){e.error?n({type:"pubnub/OBJECTS_CREATE_USER_ERROR",payload:e}):void 0!==r.data&&n({type:"pubnub/OBJECTS_CREATE_USER",payload:r.data})})}},exports.createUserActionListener=A,exports.decryptionError=E,exports.fetchMembers=function(e,r,a){return function(t){e.getMembers(C({spaceId:r},a),function(e,r){t(e.error?{type:"pubnub/OBJECTS_FETCH_MEMBERS_ERROR",payload:e}:{type:"pubnub/OBJECTS_FETCH_MEMBERS",payload:r})})}},exports.fetchMemberships=function(e,r,a){return function(t){e.getMemberships(C({userId:r},a),function(e,r){t(e.error?{type:"pubnub/OBJECTS_FETCH_MEMBERSHIPS_ERROR",payload:e}:{type:"pubnub/OBJECTS_FETCH_MEMBERSHIPS",payload:r})})}},exports.fetchSpaceById=function(e,r,a){return function(t){t({type:"pubnub/OBJECTS_FETCH_SPACE_BY_ID_BEGIN",payload:r}),e.getSpace(C({spaceId:r},a),function(e,r){t(e.error?{type:"pubnub/OBJECTS_FETCH_SPACE_BY_ID_ERROR",payload:{code:e.category,message:e.errorData,data:r.data}}:{type:"pubnub/OBJECTS_FETCH_SPACE_BY_ID",payload:{data:r.data}})})}},exports.fetchSpaces=function(e,r,a){return void 0===r&&(r={}),void 0===a&&(a="all"),function(t){t({type:"pubnub/OBJECTS_FETCH_SPACES_BEGIN",payload:{label:a}}),e.getSpaces(C({},r),function(e,r){t(e.error?P({code:e.category,message:e.errorData,data:r.data,label:a}):v({label:a,data:r.data.reduce(function(e,r){return e[r.id]=r,e},{})}))})}},exports.fetchSpacesError=P,exports.fetchUserById=function(e,r,a){return function(t){e.getUser(C({userId:r},a),function(e,r){e.error?t({type:"pubnub/OBJECTS_FETCH_USER_BY_ID_ERROR",payload:e}):void 0!==r.data&&t({type:"pubnub/OBJECTS_FETCH_USER_BY_ID",payload:r.data})})}},exports.fetchUsers=function(e,r){return function(a){e.fetchUsers(C({},r),function(e,r){a(e.error?O(e):R(r.payload))})}},exports.fetchUsersError=O,exports.malformedResponse=p,exports.membershipReducer=function(e,r){switch(void 0===e&&(e=k),r.type){case"pubnub/OBJECTS_USER_ADDED_TO_SPACE":return function(e,r){var a;return"id"in r.message.data?C({},e,{usersById:C({},e.usersById,{byId:C({},e.usersById.byId,(a={},a[r.message.data.id]=r.message.data,a)),allIds:[].concat(e.usersById.allIds,[r.message.data.id])})}):e}(e,r.payload);case"pubnub/OBJECTS_USER_REMOVED_FROM_SPACE":return function(e,r){var a=function(e,r){if(null==e)return{};var a,t,n={},o=Object.keys(e);for(t=0;t<o.length;t++)r.indexOf(a=o[t])>=0||(n[a]=e[a]);return n}(e.usersById.byId,[r.message.data.id].map(f));return C({},e,{usersById:C({},e.usersById,{byId:a,allIds:e.usersById.allIds.filter(function(e){return e!==r.message.data.id})})})}(e,r.payload);case"pubnub/OBJECTS_USER_MEMBERSHIP_UPDATED_ON_SPACE":return function(e,a){return C({},e,{user:r.payload.message.data})}(e);case"pubnub/OBJECTS_FETCH_MEMBERS":return function(e,r){var a=k;return Array.isArray(r.data)&&r.data.forEach(function(e){a.usersById.byId[e.id]=e,a.usersById.allIds=a.usersById.allIds.concat(e.id)}),C({},e,{spacesById:C({},e.usersById,{byId:a.usersById.byId,allIds:a.usersById.allIds})})}(e,r.payload);case"pubnub/OBJECTS_FETCH_MEMBERSHIPS":return function(e,r){var a=k;return Array.isArray(r.data)&&r.data.forEach(function(e){a.spacesById.byId[e.id]=e,a.spacesById.allIds=a.spacesById.allIds.concat(e.id)}),C({},e,{spacesById:C({},e.spacesById,{byId:a.spacesById.byId,allIds:a.spacesById.allIds})})}(e,r.payload);case"pubnub/OBJECTS_FETCH_MEMBERSHIPS_ERROR":case"pubnub/OBJECTS_FETCH_MEMBERS_ERROR":return function(e,r){return C({},e,{error:void 0!==r.errorData?r.errorData.error.message:r.message})}(e,r.payload);default:return e}},exports.networkDown=function(){return{type:"pubnub/NETWORK_DOWN"}},exports.networkIssues=s,exports.networkUp=function(){return{type:"pubnub/NETWORK_UP"}},exports.reconnected=d,exports.requestMessageCountExceed=b,exports.spaceDeleted=J,exports.spaceListRetrieved=v,exports.spaceUpdated=N,exports.timeoutConnection=l,exports.unknown=B,exports.userAddedToSpace=x,exports.userDeleted=g,exports.userJoin=e,exports.userLeave=r,exports.userListRetrieved=R,exports.userMembershipUpdatedOnSpace=U,exports.userReducer=function(e,r){switch(void 0===e&&(e=F),r.type){case"pubnub/OBJECTS_CREATE_USER":return function(e,r){void 0===e&&(e=F);var a=C({},e);return a[r.payload.id]=r.payload,a}(e,r);case"pubnub/OBJECTS_CREATE_USER_ERROR":return C({},e,{error:"Error while trying to create an user"});case"pubnub/OBJECTS_DELETE_USER":return function(e,r){void 0===e&&(e=F);var a=C({},e);return delete a[r.payload.id],a}(e,r);case"pubnub/OBJECTS_FETCH_USERS":return function(e,r){void 0===e&&(e=F);var a=C({},e);return r.payload.forEach(function(e){a[e.id]=e}),a}(e,r);case"pubnub/OBJECTS_FETCH_USER_BY_ID":return function(e,r){void 0===e&&(e=F);var a=C({},e);return a[r.payload.id]=r.payload,a}(e,r);case"pubnub/OBJECTS_FETCH_USERS_ERROR":case"pubnub/OBJECTS_FETCH_USER_BY_ID_ERROR":return C({},e,{error:"Error while trying to retrieve user(s)"});case"pubnub/OBJECTS_UPDATE_USER":return function(e,r){void 0===e&&(e=F);var a=C({},e);return a[r.payload.id]=r.payload,a}(e,r);default:return e}},exports.userRemovedFromSpace=h,exports.userStateChange=t,exports.userTimeout=a,exports.userUpdated=T;
//# sourceMappingURL=pubnub-redux.cjs.production.min.js.map

254

dist/pubnub-redux.esm.js

@@ -22,6 +22,6 @@ var MESSAGE = 'pubnub/MESSAGE';

var OBJECTS_CREATE_USER_ERROR = 'pubnub/OBJECTS_CREATE_USER_ERROR';
var OBJECTS_GET_USERS = 'pubnub/OBJECTS_GET_USERS';
var OBJECTS_GET_USERS_ERROR = 'pubnub/OBJECTS_GET_USERS_ERROR';
var OBJECTS_GET_USER_BY_ID = 'pubnub/OBJECTS_GET_USER_BY_ID';
var OBJECTS_GET_USER_BY_ID_ERROR = 'pubnub/OBJECTS_GET_USER_BY_ID_ERROR';
var OBJECTS_FETCH_USERS = 'pubnub/OBJECTS_FETCH_USERS';
var OBJECTS_FETCH_USERS_ERROR = 'pubnub/OBJECTS_FETCH_USERS_ERROR';
var OBJECTS_FETCH_USER_BY_ID = 'pubnub/OBJECTS_FETCH_USER_BY_ID';
var OBJECTS_FETCH_USER_BY_ID_ERROR = 'pubnub/OBJECTS_FETCH_USER_BY_ID_ERROR';
var OBJECTS_CREATE_SPACE = 'pubnub/OBJECTS_CREATE_SPACE';

@@ -36,15 +36,15 @@ var OBJECTS_CREATE_SPACE_BEGIN = 'pubnub/OBJECTS_CREATE_SPACE_BEGIN';

var OBJECTS_DELETE_SPACE_ERROR = 'pubnub/OBJECTS_DELETE_SPACE_ERROR';
var OBJECTS_GET_SPACES = 'pubnub/OBJECTS_GET_SPACES';
var OBJECTS_GET_SPACES_BEGIN = 'pubnub/OBJECTS_GET_SPACES_BEGIN';
var OBJECTS_GET_SPACES_ERROR = 'pubnub/OBJECTS_GET_SPACES_ERROR';
var OBJECTS_GET_SPACE_BY_ID = 'pubnub/OBJECTS_GET_SPACE_BY_ID';
var OBJECTS_GET_SPACE_BY_ID_BEGIN = 'pubnub/OBJECTS_GET_SPACE_BY_ID_BEGIN';
var OBJECTS_GET_SPACE_BY_ID_ERROR = 'pubnub/OBJECTS_GET_SPACE_BY_ID_ERROR';
var OBJECTS_FETCH_SPACES = 'pubnub/OBJECTS_FETCH_SPACES';
var OBJECTS_FETCH_SPACES_BEGIN = 'pubnub/OBJECTS_FETCH_SPACES_BEGIN';
var OBJECTS_FETCH_SPACES_ERROR = 'pubnub/OBJECTS_FETCH_SPACES_ERROR';
var OBJECTS_FETCH_SPACE_BY_ID = 'pubnub/OBJECTS_FETCH_SPACE_BY_ID';
var OBJECTS_FETCH_SPACE_BY_ID_BEGIN = 'pubnub/OBJECTS_FETCH_SPACE_BY_ID_BEGIN';
var OBJECTS_FETCH_SPACE_BY_ID_ERROR = 'pubnub/OBJECTS_FETCH_SPACE_BY_ID_ERROR';
var OBJECTS_USER_ADDED_TO_SPACE = 'pubnub/OBJECTS_USER_ADDED_TO_SPACE';
var OBJECTS_USER_REMOVED_FROM_SPACE = 'pubnub/OBJECTS_USER_REMOVED_FROM_SPACE';
var OBJECTS_USER_MEMBERSHIP_UPDATED_ON_SPACE = 'pubnub/OBJECTS_USER_MEMBERSHIP_UPDATED_ON_SPACE';
var OBJECTS_GET_MEMBERS = 'pubnub/OBJECTS_GET_MEMBERS';
var OBJECTS_GET_MEMBERS_ERROR = 'pubnub/OBJECTS_GET_MEMBERS_ERROR';
var OBJECTS_GET_MEMBERSHIPS = 'pubnub/OBJECTS_GET_MEMBERSHIPS';
var OBJECTS_GET_MEMBERSHIPS_ERROR = 'pubnub/OBJECTS_GET_MEMBERSHIPS_ERROR';
var OBJECTS_FETCH_MEMBERS = 'pubnub/OBJECTS_FETCH_MEMBERS';
var OBJECTS_FETCH_MEMBERS_ERROR = 'pubnub/OBJECTS_FETCH_MEMBERS_ERROR';
var OBJECTS_FETCH_MEMBERSHIPS = 'pubnub/OBJECTS_FETCH_MEMBERSHIPS';
var OBJECTS_FETCH_MEMBERSHIPS_ERROR = 'pubnub/OBJECTS_FETCH_MEMBERSHIPS_ERROR';
var SIGNAL = 'pubnub/SIGNAL';

@@ -364,3 +364,3 @@

return {
type: OBJECTS_GET_USERS,
type: OBJECTS_FETCH_USERS,
payload: payload

@@ -371,15 +371,15 @@ };

return {
type: OBJECTS_GET_USER_BY_ID,
type: OBJECTS_FETCH_USER_BY_ID,
payload: payload
};
};
var getUsersError = function getUsersError(payload) {
var fetchUsersError = function fetchUsersError(payload) {
return {
type: OBJECTS_GET_USERS_ERROR,
type: OBJECTS_FETCH_USERS_ERROR,
payload: payload
};
};
var getUserByIdError = function getUserByIdError(payload) {
var fetchUserByIdError = function fetchUserByIdError(payload) {
return {
type: OBJECTS_GET_USER_BY_ID_ERROR,
type: OBJECTS_FETCH_USER_BY_ID_ERROR,
payload: payload

@@ -408,7 +408,7 @@ };

};
var getUsers = function getUsers(pubnub, options) {
var fetchUsers = function fetchUsers(pubnub, options) {
return function (dispatch) {
pubnub.getUsers(_extends({}, options), function (status, response) {
pubnub.fetchUsers(_extends({}, options), function (status, response) {
if (status.error) {
dispatch(getUsersError(status));
dispatch(fetchUsersError(status));
} else {

@@ -420,3 +420,3 @@ dispatch(userListRetrieved(response.payload));

};
var getUserById = function getUserById(pubnub, userId, include) {
var fetchUserById = function fetchUserById(pubnub, userId, include) {
return function (dispatch) {

@@ -427,3 +427,3 @@ pubnub.getUser(_extends({

if (status.error) {
dispatch(getUserByIdError(status));
dispatch(fetchUserByIdError(status));
} else if (response.data !== undefined) {

@@ -474,14 +474,15 @@ dispatch(userRetrievedById(response.data));

return {
type: OBJECTS_GET_SPACES,
type: OBJECTS_FETCH_SPACES,
payload: payload
};
};
var getSpacesBegin = function getSpacesBegin() {
var fetchSpacesBegin = function fetchSpacesBegin(payload) {
return {
type: OBJECTS_GET_SPACES_BEGIN
type: OBJECTS_FETCH_SPACES_BEGIN,
payload: payload
};
};
var getSpacesError = function getSpacesError(payload) {
var fetchSpacesError = function fetchSpacesError(payload) {
return {
type: OBJECTS_GET_SPACES_ERROR,
type: OBJECTS_FETCH_SPACES_ERROR,
payload: payload

@@ -492,15 +493,15 @@ };

return {
type: OBJECTS_GET_SPACE_BY_ID,
type: OBJECTS_FETCH_SPACE_BY_ID,
payload: payload
};
};
var getSpaceByIdBegin = function getSpaceByIdBegin(payload) {
var fetchSpaceByIdBegin = function fetchSpaceByIdBegin(payload) {
return {
type: OBJECTS_GET_SPACE_BY_ID_BEGIN,
type: OBJECTS_FETCH_SPACE_BY_ID_BEGIN,
payload: payload
};
};
var getSpaceByIdError = function getSpaceByIdError(payload) {
var fetchSpaceByIdError = function fetchSpaceByIdError(payload) {
return {
type: OBJECTS_GET_SPACE_BY_ID_ERROR,
type: OBJECTS_FETCH_SPACE_BY_ID_ERROR,
payload: payload

@@ -542,14 +543,26 @@ };

};
var getSpaces = function getSpaces(pubnub, options) {
var fetchSpaces = function fetchSpaces(pubnub, options, label) {
if (options === void 0) {
options = {};
}
if (label === void 0) {
label = 'all';
}
return function (dispatch) {
dispatch(getSpacesBegin());
dispatch(fetchSpacesBegin({
label: label
}));
pubnub.getSpaces(_extends({}, options), function (status, response) {
if (status.error) {
dispatch(getSpacesError({
dispatch(fetchSpacesError({
code: status.category,
message: status.errorData,
data: response.data
data: response.data,
label: label
}));
} else {
dispatch(spaceListRetrieved({
label: label,
data: response.data.reduce(function (result, value) {

@@ -564,5 +577,5 @@ result[value.id] = value;

};
var getSpaceById = function getSpaceById(pubnub, spaceId, include) {
var fetchSpaceById = function fetchSpaceById(pubnub, spaceId, include) {
return function (dispatch) {
dispatch(getSpaceByIdBegin(spaceId));
dispatch(fetchSpaceByIdBegin(spaceId));
pubnub.getSpace(_extends({

@@ -572,3 +585,3 @@ spaceId: spaceId

if (status.error) {
dispatch(getSpaceByIdError({
dispatch(fetchSpaceByIdError({
code: status.category,

@@ -630,3 +643,3 @@ message: status.errorData,

return {
type: OBJECTS_GET_MEMBERS,
type: OBJECTS_FETCH_MEMBERS,
payload: payload

@@ -638,3 +651,3 @@ };

return {
type: OBJECTS_GET_MEMBERSHIPS,
type: OBJECTS_FETCH_MEMBERSHIPS,
payload: payload

@@ -644,5 +657,5 @@ };

var getMembershipsError = function getMembershipsError(payload) {
var fetchMembershipsError = function fetchMembershipsError(payload) {
return {
type: OBJECTS_GET_MEMBERSHIPS_ERROR,
type: OBJECTS_FETCH_MEMBERSHIPS_ERROR,
payload: payload

@@ -652,5 +665,5 @@ };

var getMembersError = function getMembersError(payload) {
var fetchMembersError = function fetchMembersError(payload) {
return {
type: OBJECTS_GET_MEMBERS_ERROR,
type: OBJECTS_FETCH_MEMBERS_ERROR,
payload: payload

@@ -660,3 +673,3 @@ };

var getMembers = function getMembers(pubnub, spaceId, options) {
var fetchMembers = function fetchMembers(pubnub, spaceId, options) {
return function (dispatch) {

@@ -667,3 +680,3 @@ pubnub.getMembers(_extends({

if (status.error) {
dispatch(getMembersError(status));
dispatch(fetchMembersError(status));
} else {

@@ -675,3 +688,3 @@ dispatch(memberListRetrieved(response));

};
var getMemberships = function getMemberships(pubnub, userId, options) {
var fetchMemberships = function fetchMemberships(pubnub, userId, options) {
return function (dispatch) {

@@ -682,3 +695,3 @@ pubnub.getMemberships(_extends({

if (status.error) {
dispatch(getMembershipsError(status));
dispatch(fetchMembershipsError(status));
} else {

@@ -904,10 +917,10 @@ dispatch(membershipsRetrieved(response));

case OBJECTS_GET_USERS:
case OBJECTS_FETCH_USERS:
return addUsers(state, action);
case OBJECTS_GET_USER_BY_ID:
case OBJECTS_FETCH_USER_BY_ID:
return addUser(state, action);
case OBJECTS_GET_USERS_ERROR:
case OBJECTS_GET_USER_BY_ID_ERROR:
case OBJECTS_FETCH_USERS_ERROR:
case OBJECTS_FETCH_USER_BY_ID_ERROR:
return _extends({}, state, {

@@ -1061,3 +1074,3 @@ error: 'Error while trying to retrieve user(s)'

var beginGetSpaces = function beginGetSpaces(state) {
var beginFetchSpaces = function beginFetchSpaces(state) {
return _extends({}, state, {

@@ -1072,3 +1085,3 @@ data: _extends({}, state.data),

var getSpaces$1 = function getSpaces(state, payload) {
var fetchSpaces$1 = function fetchSpaces(state, payload) {
return _extends({}, state, {

@@ -1082,3 +1095,3 @@ data: _extends({}, payload.data),

var getSpacesError$1 = function getSpacesError(state, payload) {
var fetchSpacesError$1 = function fetchSpacesError(state, payload) {
return _extends({}, state, {

@@ -1092,3 +1105,3 @@ loadingById: _extends({}, state.loadingById),

var beginGetSpaceById = function beginGetSpaceById(state, payload) {
var beginFetchSpaceById = function beginFetchSpaceById(state, payload) {
var newState = _extends({}, state, {

@@ -1107,3 +1120,3 @@ data: _extends({}, state.data),

var getSpaceById$1 = function getSpaceById(state, payload) {
var fetchSpaceById$1 = function fetchSpaceById(state, payload) {
var newState = _extends({}, state, {

@@ -1122,3 +1135,3 @@ data: _extends({}, state.data),

var getSpaceError = function getSpaceError(state, payload) {
var fetchSpaceError = function fetchSpaceError(state, payload) {
var newState = _extends({}, state, {

@@ -1171,26 +1184,20 @@ data: _extends({}, state.data),

case OBJECTS_GET_SPACES_BEGIN:
return beginGetSpaces(state);
case OBJECTS_FETCH_SPACES_BEGIN:
return beginFetchSpaces(state);
case OBJECTS_GET_SPACES:
return getSpaces$1(state, action.payload);
case OBJECTS_FETCH_SPACES:
return fetchSpaces$1(state, action.payload);
case OBJECTS_GET_SPACES_ERROR:
return getSpacesError$1(state, action.payload);
case OBJECTS_FETCH_SPACES_ERROR:
return fetchSpacesError$1(state, action.payload);
case OBJECTS_GET_SPACE_BY_ID_BEGIN:
return beginGetSpaceById(state, action.payload);
case OBJECTS_FETCH_SPACE_BY_ID_BEGIN:
return beginFetchSpaceById(state, action.payload);
case OBJECTS_GET_SPACE_BY_ID:
return getSpaceById$1(state, action.payload);
case OBJECTS_FETCH_SPACE_BY_ID:
return fetchSpaceById$1(state, action.payload);
case OBJECTS_GET_SPACE_BY_ID_ERROR:
return getSpaceError(state, action.payload);
case OBJECTS_FETCH_SPACE_BY_ID_ERROR:
return fetchSpaceError(state, action.payload);
case OBJECTS_UPDATE_SPACE:
return updateSpace(state, action.payload);
case OBJECTS_UPDATE_SPACE_ERROR:
return updateSpaceError(state, action.payload);
default:

@@ -1202,2 +1209,67 @@ return state;

var createInitialState$1 = function createInitialState() {
return {
data: [],
loading: false,
error: undefined
};
};
var beginFetchSpaces$1 = function beginFetchSpaces(state) {
return {
data: [].concat(state.data),
loading: true,
error: undefined
};
};
var fetchSpaces$2 = function fetchSpaces(payload) {
var data = Object.keys(payload.data).map(function (key) {
return payload.data[key].id;
});
return {
data: data,
loading: false,
error: undefined
};
};
var fetchSpacesError$2 = function fetchSpacesError(state, payload) {
return {
data: [].concat(state.data),
loading: false,
error: payload
};
};
var createSpaceListReducer = function createSpaceListReducer(label) {
if (label === void 0) {
label = 'all';
}
return function (state, action) {
if (state === void 0) {
state = createInitialState$1();
}
if (action.payload !== undefined && action.payload.label === label) {
switch (action.type) {
case OBJECTS_FETCH_SPACES_BEGIN:
return beginFetchSpaces$1(state);
case OBJECTS_FETCH_SPACES:
return fetchSpaces$2(action.payload);
case OBJECTS_FETCH_SPACES_ERROR:
return fetchSpacesError$2(state, action.payload);
default:
return state;
}
} else {
return state;
}
};
};
var initialState$1 = {

@@ -1250,3 +1322,3 @@ usersById: {

var getMembers$1 = function getMembers(state, payload) {
var fetchMembers$1 = function fetchMembers(state, payload) {
var receivedUsers = initialState$1;

@@ -1269,3 +1341,3 @@

var getMembeberships = function getMembeberships(state, payload) {
var fetchMembeberships = function fetchMembeberships(state, payload) {
var receivedSpaces = initialState$1;

@@ -1288,3 +1360,3 @@

var getMemberError = function getMemberError(state, payload) {
var fetchMemberError = function fetchMemberError(state, payload) {
return _extends({}, state, {

@@ -1310,11 +1382,11 @@ error: payload.errorData !== undefined ? payload.errorData.error.message : payload.message

case OBJECTS_GET_MEMBERS:
return getMembers$1(state, action.payload);
case OBJECTS_FETCH_MEMBERS:
return fetchMembers$1(state, action.payload);
case OBJECTS_GET_MEMBERSHIPS:
return getMembeberships(state, action.payload);
case OBJECTS_FETCH_MEMBERSHIPS:
return fetchMembeberships(state, action.payload);
case OBJECTS_GET_MEMBERSHIPS_ERROR:
case OBJECTS_GET_MEMBERS_ERROR:
return getMemberError(state, action.payload);
case OBJECTS_FETCH_MEMBERSHIPS_ERROR:
case OBJECTS_FETCH_MEMBERS_ERROR:
return fetchMemberError(state, action.payload);

@@ -1326,3 +1398,3 @@ default:

export { accessDenied, badRequest, combineListeners, connected, createErrorStatusActionListener, createMembershipActionListener, createMessageActionListener, createNetworkStatusActionListener, createNetworkStatusReducer, createPresenceActionListener, createPubNubActionListener, createSignalActionListener, createSpace, createSpaceActionListener, createSpaceReducer, createSubscribeStatusActionListener, createUser, createUserActionListener, decryptionError, getMembers, getMemberships, getSpaceById, getSpaces, getSpacesError, getUserById, getUsers, getUsersError, malformedResponse, membershipReducer, networkDown, networkIssues, networkUp, reconnected, requestMessageCountExceed, spaceDeleted, spaceListRetrieved, spaceUpdated, timeoutConnection, unknown, userAddedToSpace, userDeleted, userJoin, userLeave, userListRetrieved, userMembershipUpdatedOnSpace, userReducer, userRemovedFromSpace, userStateChange, userTimeout, userUpdated };
export { accessDenied, badRequest, combineListeners, connected, createErrorStatusActionListener, createMembershipActionListener, createMessageActionListener, createNetworkStatusActionListener, createNetworkStatusReducer, createPresenceActionListener, createPubNubActionListener, createSignalActionListener, createSpace, createSpaceActionListener, createSpaceListReducer, createSpaceReducer, createSubscribeStatusActionListener, createUser, createUserActionListener, decryptionError, fetchMembers, fetchMemberships, fetchSpaceById, fetchSpaces, fetchSpacesError, fetchUserById, fetchUsers, fetchUsersError, malformedResponse, membershipReducer, networkDown, networkIssues, networkUp, reconnected, requestMessageCountExceed, spaceDeleted, spaceListRetrieved, spaceUpdated, timeoutConnection, unknown, userAddedToSpace, userDeleted, userJoin, userLeave, userListRetrieved, userMembershipUpdatedOnSpace, userReducer, userRemovedFromSpace, userStateChange, userTimeout, userUpdated };
//# sourceMappingURL=pubnub-redux.esm.js.map

2

dist/reducers/membershipReducer.d.ts

@@ -15,3 +15,3 @@ import { ObjectsData } from '../types/Objects';

}
export declare const membershipReducer: <T extends Identifiable>(state: MembershipState | undefined, action: import("../types/actions").GetMembershipsAction | import("../types/actions").GetMembersAction | import("../types/actions").GetMemershipsErrorAction | import("../types/actions").GetMembersErrorAction | import("../types/actions").UserAddedToSpaceAction<T> | import("../types/actions").UserRemovedFromSpaceAction<T> | import("../types/actions").UserMembershipUpdatedOnSpaceAction<T>) => MembershipState;
export declare const membershipReducer: <T extends Identifiable>(state: MembershipState | undefined, action: import("../types/actions").FetchMembershipsAction | import("../types/actions").FetchMembersAction | import("../types/actions").FetchMemershipsErrorAction | import("../types/actions").FetchMembersErrorAction | import("../types/actions").UserAddedToSpaceAction<T> | import("../types/actions").UserRemovedFromSpaceAction<T> | import("../types/actions").UserMembershipUpdatedOnSpaceAction<T>) => MembershipState;
export {};

4

dist/reducers/spaceReducer.d.ts
import { SpaceActions } from '../types/actions';
import { PubNubApiState, Identifiable } from '../types/PubNubApi';
export declare const createSpaceReducer: <T extends Identifiable>() => (state: PubNubApiState<T> | undefined, action: SpaceActions<T>) => PubNubApiState<T>;
import { PubNubObjectApiState, Identifiable } from '../types/PubNubApi';
export declare const createSpaceReducer: <T extends Identifiable>() => (state: PubNubObjectApiState<T> | undefined, action: SpaceActions<T>) => PubNubObjectApiState<T>;

4

dist/reducers/userReducer.d.ts

@@ -1,2 +0,2 @@

import { UserUpdatedAction, UserDeletedAction, UserCreatedAction, UserListRetrievedAction, GetUserByIdAction } from '../types/actions';
export declare const userReducer: (state: {} | undefined, action: UserCreatedAction | UserUpdatedAction | UserDeletedAction | UserListRetrievedAction | GetUserByIdAction | import("../types/actions").CreateUserErrorAction | import("../types/actions").GetUsersErrorAction | import("../types/actions").GetUserByIdErrorAction) => {};
import { UserUpdatedAction, UserDeletedAction, UserCreatedAction, UserListRetrievedAction, FetchUserByIdAction } from '../types/actions';
export declare const userReducer: (state: {} | undefined, action: UserCreatedAction | UserUpdatedAction | UserDeletedAction | UserListRetrievedAction | FetchUserByIdAction | import("../types/actions").CreateUserErrorAction | import("../types/actions").FetchUsersErrorAction | import("../types/actions").FetchUserByIdErrorAction) => {};

115

dist/types/actions.d.ts

@@ -8,3 +8,3 @@ import { MessageActionPayload } from './Message';

import { SpaceMap } from './Space';
import { PubNubApiSuccess, PubNubApiError, Identifiable } from './PubNubApi';
import { PubNubObjectApiSuccess, PubNubObjectApiError, Identifiable } from './PubNubApi';
export declare const MESSAGE = "pubnub/MESSAGE";

@@ -31,6 +31,6 @@ export declare const JOIN = "pubnub/JOIN";

export declare const OBJECTS_CREATE_USER_ERROR = "pubnub/OBJECTS_CREATE_USER_ERROR";
export declare const OBJECTS_GET_USERS = "pubnub/OBJECTS_GET_USERS";
export declare const OBJECTS_GET_USERS_ERROR = "pubnub/OBJECTS_GET_USERS_ERROR";
export declare const OBJECTS_GET_USER_BY_ID = "pubnub/OBJECTS_GET_USER_BY_ID";
export declare const OBJECTS_GET_USER_BY_ID_ERROR = "pubnub/OBJECTS_GET_USER_BY_ID_ERROR";
export declare const OBJECTS_FETCH_USERS = "pubnub/OBJECTS_FETCH_USERS";
export declare const OBJECTS_FETCH_USERS_ERROR = "pubnub/OBJECTS_FETCH_USERS_ERROR";
export declare const OBJECTS_FETCH_USER_BY_ID = "pubnub/OBJECTS_FETCH_USER_BY_ID";
export declare const OBJECTS_FETCH_USER_BY_ID_ERROR = "pubnub/OBJECTS_FETCH_USER_BY_ID_ERROR";
export declare const OBJECTS_CREATE_SPACE = "pubnub/OBJECTS_CREATE_SPACE";

@@ -45,15 +45,15 @@ export declare const OBJECTS_CREATE_SPACE_BEGIN = "pubnub/OBJECTS_CREATE_SPACE_BEGIN";

export declare const OBJECTS_DELETE_SPACE_ERROR = "pubnub/OBJECTS_DELETE_SPACE_ERROR";
export declare const OBJECTS_GET_SPACES = "pubnub/OBJECTS_GET_SPACES";
export declare const OBJECTS_GET_SPACES_BEGIN = "pubnub/OBJECTS_GET_SPACES_BEGIN";
export declare const OBJECTS_GET_SPACES_ERROR = "pubnub/OBJECTS_GET_SPACES_ERROR";
export declare const OBJECTS_GET_SPACE_BY_ID = "pubnub/OBJECTS_GET_SPACE_BY_ID";
export declare const OBJECTS_GET_SPACE_BY_ID_BEGIN = "pubnub/OBJECTS_GET_SPACE_BY_ID_BEGIN";
export declare const OBJECTS_GET_SPACE_BY_ID_ERROR = "pubnub/OBJECTS_GET_SPACE_BY_ID_ERROR";
export declare const OBJECTS_FETCH_SPACES = "pubnub/OBJECTS_FETCH_SPACES";
export declare const OBJECTS_FETCH_SPACES_BEGIN = "pubnub/OBJECTS_FETCH_SPACES_BEGIN";
export declare const OBJECTS_FETCH_SPACES_ERROR = "pubnub/OBJECTS_FETCH_SPACES_ERROR";
export declare const OBJECTS_FETCH_SPACE_BY_ID = "pubnub/OBJECTS_FETCH_SPACE_BY_ID";
export declare const OBJECTS_FETCH_SPACE_BY_ID_BEGIN = "pubnub/OBJECTS_FETCH_SPACE_BY_ID_BEGIN";
export declare const OBJECTS_FETCH_SPACE_BY_ID_ERROR = "pubnub/OBJECTS_FETCH_SPACE_BY_ID_ERROR";
export declare const OBJECTS_USER_ADDED_TO_SPACE = "pubnub/OBJECTS_USER_ADDED_TO_SPACE";
export declare const OBJECTS_USER_REMOVED_FROM_SPACE = "pubnub/OBJECTS_USER_REMOVED_FROM_SPACE";
export declare const OBJECTS_USER_MEMBERSHIP_UPDATED_ON_SPACE = "pubnub/OBJECTS_USER_MEMBERSHIP_UPDATED_ON_SPACE";
export declare const OBJECTS_GET_MEMBERS = "pubnub/OBJECTS_GET_MEMBERS";
export declare const OBJECTS_GET_MEMBERS_ERROR = "pubnub/OBJECTS_GET_MEMBERS_ERROR";
export declare const OBJECTS_GET_MEMBERSHIPS = "pubnub/OBJECTS_GET_MEMBERSHIPS";
export declare const OBJECTS_GET_MEMBERSHIPS_ERROR = "pubnub/OBJECTS_GET_MEMBERSHIPS_ERROR";
export declare const OBJECTS_FETCH_MEMBERS = "pubnub/OBJECTS_FETCH_MEMBERS";
export declare const OBJECTS_FETCH_MEMBERS_ERROR = "pubnub/OBJECTS_FETCH_MEMBERS_ERROR";
export declare const OBJECTS_FETCH_MEMBERSHIPS = "pubnub/OBJECTS_FETCH_MEMBERSHIPS";
export declare const OBJECTS_FETCH_MEMBERSHIPS_ERROR = "pubnub/OBJECTS_FETCH_MEMBERSHIPS_ERROR";
export declare const SIGNAL = "pubnub/SIGNAL";

@@ -142,34 +142,37 @@ export interface JoinAction {

export interface UserListRetrievedAction {
type: typeof OBJECTS_GET_USERS;
type: typeof OBJECTS_FETCH_USERS;
payload: User[];
}
export interface GetUsersErrorAction {
type: typeof OBJECTS_GET_USERS_ERROR;
export interface FetchUsersErrorAction {
type: typeof OBJECTS_FETCH_USERS_ERROR;
payload: ObjectsStatusPayload;
}
export interface GetUserByIdErrorAction {
type: typeof OBJECTS_GET_USER_BY_ID_ERROR;
export interface FetchUserByIdErrorAction {
type: typeof OBJECTS_FETCH_USER_BY_ID_ERROR;
payload: ObjectsStatusPayload;
}
export interface GetUserByIdAction {
type: typeof OBJECTS_GET_USER_BY_ID;
export interface FetchUserByIdAction {
type: typeof OBJECTS_FETCH_USER_BY_ID;
payload: User;
}
export interface GetUserByIdErrorAction {
type: typeof OBJECTS_GET_USER_BY_ID_ERROR;
export interface FetchUserByIdErrorAction {
type: typeof OBJECTS_FETCH_USER_BY_ID_ERROR;
}
export interface SpaceListRetrievedAction<T> {
type: typeof OBJECTS_GET_SPACES;
payload: PubNubApiSuccess<SpaceMap<T>>;
type: typeof OBJECTS_FETCH_SPACES;
payload: PubNubObjectApiSuccess<SpaceMap<T>>;
}
export interface GetSpacesBeginAction {
type: typeof OBJECTS_GET_SPACES_BEGIN;
export interface FetchSpacesBeginAction {
type: typeof OBJECTS_FETCH_SPACES_BEGIN;
payload: {
label: string;
};
}
export interface GetSpacesErrorAction {
type: typeof OBJECTS_GET_SPACES_ERROR;
payload: PubNubApiError;
export interface FetchSpacesErrorAction {
type: typeof OBJECTS_FETCH_SPACES_ERROR;
payload: PubNubObjectApiError;
}
export interface SpaceCreatedAction<T> {
type: typeof OBJECTS_CREATE_SPACE;
payload: PubNubApiSuccess<T>;
payload: PubNubObjectApiSuccess<T>;
}

@@ -182,7 +185,7 @@ export interface CreateSpaceBeginAction<T> {

type: typeof OBJECTS_CREATE_SPACE_ERROR;
payload: PubNubApiError<T>;
payload: PubNubObjectApiError<T>;
}
export interface SpaceUpdatedAction<T> {
type: typeof OBJECTS_UPDATE_SPACE;
payload: PubNubApiSuccess<T>;
payload: PubNubObjectApiSuccess<T>;
}

@@ -195,7 +198,7 @@ export interface UpdateSpaceBeginAction<T> {

type: typeof OBJECTS_UPDATE_SPACE_ERROR;
payload: PubNubApiError<T>;
payload: PubNubObjectApiError<T>;
}
export interface SpaceDeletedAction<T> {
type: typeof OBJECTS_DELETE_SPACE;
payload: PubNubApiSuccess<T>;
payload: PubNubObjectApiSuccess<T>;
}

@@ -208,15 +211,15 @@ export interface DeleteSpaceBeginAction {

type: typeof OBJECTS_DELETE_SPACE_ERROR;
payload: PubNubApiError<T>;
payload: PubNubObjectApiError<T>;
}
export interface GetSpaceByIdAction<T> {
type: typeof OBJECTS_GET_SPACE_BY_ID;
payload: PubNubApiSuccess<T>;
export interface FetchSpaceByIdAction<T> {
type: typeof OBJECTS_FETCH_SPACE_BY_ID;
payload: PubNubObjectApiSuccess<T>;
}
export interface GetSpaceByIdBeginAction {
type: typeof OBJECTS_GET_SPACE_BY_ID_BEGIN;
export interface FetchSpaceByIdBeginAction {
type: typeof OBJECTS_FETCH_SPACE_BY_ID_BEGIN;
payload: string;
}
export interface GetSpaceByIdErrorAction<T> {
type: typeof OBJECTS_GET_SPACE_BY_ID_ERROR;
payload: PubNubApiError<T>;
export interface FetchSpaceByIdErrorAction<T> {
type: typeof OBJECTS_FETCH_SPACE_BY_ID_ERROR;
payload: PubNubObjectApiError<T>;
}

@@ -235,16 +238,16 @@ export interface UserAddedToSpaceAction<T extends Identifiable> {

}
export interface GetMembersAction {
type: typeof OBJECTS_GET_MEMBERS;
export interface FetchMembersAction {
type: typeof OBJECTS_FETCH_MEMBERS;
payload: ObjectsResponsePayload;
}
export interface GetMembersErrorAction {
type: typeof OBJECTS_GET_MEMBERS_ERROR;
export interface FetchMembersErrorAction {
type: typeof OBJECTS_FETCH_MEMBERS_ERROR;
payload: ObjectsStatusPayload;
}
export interface GetMembershipsAction {
type: typeof OBJECTS_GET_MEMBERSHIPS;
export interface FetchMembershipsAction {
type: typeof OBJECTS_FETCH_MEMBERSHIPS;
payload: ObjectsResponsePayload;
}
export interface GetMemershipsErrorAction {
type: typeof OBJECTS_GET_MEMBERSHIPS_ERROR;
export interface FetchMemershipsErrorAction {
type: typeof OBJECTS_FETCH_MEMBERSHIPS_ERROR;
payload: ObjectsStatusPayload;

@@ -265,5 +268,5 @@ }

export declare type StatusListenerActions = NetworkStatusListenerActions | SubscriptionStatusListenerActions | ErrorStatusListenerActions;
export declare type UserActions = UserCreatedAction | CreateUserErrorAction | UserListRetrievedAction | GetUsersErrorAction | GetUserByIdAction | GetUserByIdErrorAction;
export declare type SpaceActions<T> = SpaceCreatedAction<T> | CreateSpaceBeginAction<T> | CreateSpaceErrorAction<T> | SpaceUpdatedAction<T> | UpdateSpaceBeginAction<T> | UpdateSpaceErrorAction<T> | SpaceDeletedAction<T> | DeleteSpaceBeginAction | DeleteSpaceErrorAction<T> | SpaceListRetrievedAction<T> | GetSpacesBeginAction | GetSpacesErrorAction | GetSpaceByIdAction<T> | GetSpaceByIdBeginAction | GetSpaceByIdErrorAction<T>;
export declare type MembershipActions = GetMembershipsAction | GetMembersAction | GetMemershipsErrorAction | GetMembersErrorAction;
export declare type UserActions = UserCreatedAction | CreateUserErrorAction | UserListRetrievedAction | FetchUsersErrorAction | FetchUserByIdAction | FetchUserByIdErrorAction;
export declare type SpaceActions<T> = SpaceCreatedAction<T> | CreateSpaceBeginAction<T> | CreateSpaceErrorAction<T> | SpaceUpdatedAction<T> | UpdateSpaceBeginAction<T> | UpdateSpaceErrorAction<T> | SpaceDeletedAction<T> | DeleteSpaceBeginAction | DeleteSpaceErrorAction<T> | SpaceListRetrievedAction<T> | FetchSpacesBeginAction | FetchSpacesErrorAction | FetchSpaceByIdAction<T> | FetchSpaceByIdBeginAction | FetchSpaceByIdErrorAction<T>;
export declare type MembershipActions = FetchMembershipsAction | FetchMembersAction | FetchMemershipsErrorAction | FetchMembersErrorAction;
export declare type UserListenerActions = UserUpdatedAction | UserDeletedAction;

@@ -270,0 +273,0 @@ export declare type SpaceListenerActions<T> = SpaceUpdatedAction<T> | SpaceDeletedAction<T>;

14

dist/types/PubNubApi.d.ts

@@ -8,14 +8,16 @@ export interface PubNubApiStatus {

}
export interface Identifiable {
export interface Identifiable extends Object {
id: string;
}
export interface PubNubApiSuccess<T> {
export interface PubNubObjectApiSuccess<T> {
data: T;
label?: string;
}
export interface PubNubApiError<T = object> {
export interface PubNubObjectApiError<T = object> {
code: string;
message: string;
data: T;
label?: string;
}
export interface PubNubApiState<T> {
export interface PubNubObjectApiState<T> {
data: {

@@ -28,6 +30,6 @@ [key: string]: T;

};
errorAll?: PubNubApiError;
errorAll?: PubNubObjectApiError;
errorById: {
[key: string]: PubNubApiError<T>;
[key: string]: PubNubObjectApiError<T>;
};
}

2

package.json
{
"name": "pubnub-redux",
"version": "0.1.4-alpha",
"version": "0.1.5-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