Huge News!Announcing our $40M Series B led by Abstract Ventures.Learn More →
pusher-redux
Advanced tools
pusher-redux - npm Package Compare versions
Comparing version 0.0.1 to 0.1.1
114
index.js
| 'use strict'; | ||
| var Pusher = require('pusher-js'); | ||
| // on the one hand having global state is ugly, on the other it is easier to use it from anywhere | ||
| var config = { | ||
| socket: null, | ||
| store: null, | ||
| apiKey: null, | ||
| options: {}, | ||
| subscriptions: {} | ||
| }; | ||
| // create redux action | ||
| var pusherAction = function pusherAction(_ref) { | ||
| var actionType = _ref.actionType; | ||
| var channelName = _ref.channelName; | ||
| var eventName = _ref.eventName; | ||
| var data = _ref.data; | ||
| return { | ||
| type: actionType, | ||
| channel: channelName, | ||
| event: eventName, | ||
| data: data | ||
| }; | ||
| }; | ||
| // we need to wait before pusher connects until we can subscribe | ||
| // so gonna queue actions here | ||
| var pendingFunctions = []; | ||
| var isConnected = false; | ||
| var addToQueue = function addToQueue(func) { | ||
| pendingFunctions.push(func); | ||
| runPending(); | ||
| }; | ||
| var successfullyConnected = function successfullyConnected() { | ||
| isConnected = true; | ||
| runPending(); | ||
| }; | ||
| var runPending = function runPending() { | ||
| // that's like a promise, but I don't want to depend on promises | ||
| while (isConnected && pendingFunctions.length > 0) { | ||
| pendingFunctions.shift()(); | ||
| } | ||
| }; | ||
| module.exports.configurePusher = function (store, apiKey) { | ||
| var options = arguments.length > 2 && arguments[2] !== undefined ? arguments[2] : {}; | ||
| config.socket = new Pusher(apiKey, options); | ||
| config.store = store; | ||
| config.apiKey = apiKey; | ||
| config.socket.connection.bind('connected', successfullyConnected); | ||
| }; | ||
| module.exports.delayConfiguration = function (store, apiKey) { | ||
| var options = arguments.length > 2 && arguments[2] !== undefined ? arguments[2] : {}; | ||
| config.store = store; | ||
| config.apiKey = apiKey; | ||
| Object.assign(config.options, options); | ||
| }; | ||
| module.exports.startConfiguration = function () { | ||
| var options = arguments.length > 0 && arguments[0] !== undefined ? arguments[0] : {}; | ||
| config.socket = new Pusher(config.apiKey, Object.assign({}, config.options, options)); | ||
| config.socket.connection.bind('connected', successfullyConnected); | ||
| }; | ||
| module.exports.subscribe = function (channelName, eventName, actionType) { | ||
| addToQueue(function () { | ||
| var channel = config.socket.channel(channelName) || config.socket.subscribe(channelName); | ||
| if (!config.subscriptions[channelName]) { | ||
| config.subscriptions[channelName] = {}; | ||
| } | ||
| var channelSubs = config.subscriptions[channelName]; | ||
| if (!channelSubs[eventName]) { | ||
| channelSubs[eventName] = {}; | ||
| } | ||
| var eventSubs = channelSubs[eventName]; | ||
| if (!eventSubs[actionType]) { | ||
| eventSubs[actionType] = function (data) { | ||
| config.store.dispatch(pusherAction({ actionType: actionType, channelName: channelName, eventName: eventName, data: data })); | ||
| }; | ||
| channel.bind(eventName, eventSubs[actionType]); | ||
| } | ||
| }); | ||
| }; | ||
| module.exports.unsubscribe = function (channelName, eventName, actionType) { | ||
| addToQueue(function () { | ||
| var channel = config.socket.channel(channelName); | ||
| if (!channel) { | ||
| console.log('Not subscribed to \'' + channelName + '\''); | ||
| return; | ||
| } | ||
| var channelSubs = config.subscriptions[channelName]; | ||
| if (!channelSubs[eventName]) { | ||
| console.log('Not subscribed event \'' + eventName + '\' from \'' + channelName + '\''); | ||
| return; | ||
| } | ||
| var eventSubs = channelSubs[eventName]; | ||
| if (!eventSubs[actionType]) { | ||
| console.log('Handler ' + actionType + ' not registered for event \'' + eventName + '\' from \'' + channelName + '\''); | ||
| return; | ||
| } | ||
| channel.unbind(eventName, eventSubs[actionType]); | ||
| delete eventSubs[actionType]; | ||
| }); | ||
| }; | ||
| var pusherRedux = require('./pusher-redux'); | ||
| pusherRedux.setPusherClient(Pusher); | ||
| module.exports = pusherRedux; |
| { | ||
| "name": "pusher-redux", | ||
| "version": "0.0.1", | ||
| "version": "0.1.1", | ||
| "description": "Integration of Pusher into Redux", | ||
@@ -5,0 +5,0 @@ "main": "index.js", |
@@ -67,3 +67,3 @@ pusher-redux | ||
| ... | ||
| function orderReducer(state = initialState.orders), action) { | ||
| function orderReducer(state = initialState.orders, action) { | ||
| case NEW_ORDER: | ||
@@ -120,2 +120,11 @@ return [...state, action.data.order]; | ||
| ## React Native | ||
| If you want to use react-native then replace ALL imports of `pusher-redux` with `pusher-redux/react-native` | ||
| e.g. | ||
| <pre> | ||
| <code> | ||
| import { startConfiguration } from 'pusher-redux/react-native'; | ||
| </code> | ||
| </pre> | ||
| ### Options | ||
@@ -122,0 +131,0 @@ |
New alerts
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
Major refactor
Supply chain riskPackage has recently undergone a major refactor. It may be unstable or indicate significant internal changes. Use caution when updating to versions that include significant changes.
Found 1 instance in 1 package
Fixed alerts
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
Improved metrics
- Total package byte prevSize
- increased by6.46%
8638
- Number of package files
- increased by50%
6
- Lines of code
- increased by13.13%
112
- Number of lines in readme file
- increased by7.03%
137
Worsened metrics
- Number of medium supply chain risk alerts
- increased byInfinity%
1
No dependency changes