Huge News!Announcing our $40M Series B led by Abstract Ventures.Learn More →
sse-broadcast-redis2
Advanced tools
sse-broadcast-redis2 - npm Package Compare versions
Comparing version 0.1.1 to 0.1.2
150
index.js
@@ -1,104 +0,74 @@ | ||
| 'use strict' | ||
| exports = module.exports = SSEBroadcasterRedisAdapter | ||
| var assert = require('assert'), | ||
| inherits = require('util').inherits, | ||
| EventEmitter = require('events'), | ||
| Broadcaster = require('sse-broadcast'), | ||
| redis = require('redis'), | ||
| id = require('mdbid') | ||
| function SSEBroadcasterRedisAdapter (broadcaster, optionsOrClient) { | ||
| if (!(this instanceof SSEBroadcasterRedisAdapter)) | ||
| return new SSEBroadcasterRedisAdapter(broadcaster, optionsOrClient) | ||
| assert(broadcaster, 'a broadcaster instance is required') | ||
| assert( | ||
| broadcaster instanceof Broadcaster, | ||
| 'broadcaster must be an instance of SSEBroadcaster' | ||
| ) | ||
| this.id = id() | ||
| this.broadcaster = broadcaster | ||
| "use strict"; | ||
| var __importDefault = (this && this.__importDefault) || function (mod) { | ||
| return (mod && mod.__esModule) ? mod : { "default": mod }; | ||
| }; | ||
| Object.defineProperty(exports, "__esModule", { value: true }); | ||
| exports.SSEBroadcasterRedisAdapter = void 0; | ||
| var assert = require('assert'), inherits = require('util').inherits, EventEmitter = require('events'), Broadcaster = require('sse-broadcast'), id = require('mdbid'); | ||
| const redis_1 = __importDefault(require("redis")); | ||
| const SSEBroadcasterRedisAdapter = (broadcaster, optionsOrClient) => { | ||
| if (!this || !(this instanceof exports.SSEBroadcasterRedisAdapter)) { | ||
| return new exports.SSEBroadcasterRedisAdapter(broadcaster, optionsOrClient); | ||
| } | ||
| assert(broadcaster, 'a broadcaster instance is required'); | ||
| assert(broadcaster instanceof Broadcaster, 'broadcaster must be an instance of SSEBroadcaster')(this).id = id()(this).broadcaster = broadcaster; | ||
| if (optionsOrClient.ECHO) { | ||
| this.pub = optionsOrClient | ||
| this.sub = optionsOrClient.duplicate() | ||
| this.pub = optionsOrClient; | ||
| this.sub = optionsOrClient.duplicate(); | ||
| } | ||
| else { | ||
| this.pub = redis.createClient(optionsOrClient) | ||
| this.sub = redis.createClient(optionsOrClient) | ||
| this.pub = redis_1.default.createClient(optionsOrClient); | ||
| this.sub = redis_1.default.createClient(optionsOrClient); | ||
| } | ||
| broadcaster.on('publish', this.onpublish.bind(this)) | ||
| broadcaster.on('subscribe', this.onsubscribe.bind(this)) | ||
| broadcaster.on('unsubscribe', this.onunsubscribe.bind(this)) | ||
| this.pub.on('error', this.onerror.bind(this)) | ||
| this.sub.on('error', this.onerror.bind(this)) | ||
| this.sub.on('pmessage', this.onpmessage.bind(this)) | ||
| } | ||
| inherits(SSEBroadcasterRedisAdapter, EventEmitter) | ||
| // static properties | ||
| broadcaster.on('publish', this.onpublish.bind(this)); | ||
| broadcaster.on('subscribe', this.onsubscribe.bind(this)); | ||
| broadcaster.on('unsubscribe', this.onunsubscribe.bind(this))(this).pub.on('error', this.onerror.bind(this))(this).sub.on('error', this.onerror.bind(this))(this).sub.on('pmessage', this.onpmessage.bind(this)); | ||
| }; | ||
| exports.SSEBroadcasterRedisAdapter = SSEBroadcasterRedisAdapter; | ||
| inherits(exports.SSEBroadcasterRedisAdapter, EventEmitter); | ||
| Object.defineProperties(exports, { | ||
| Adapter: { | ||
| enumerable: true, | ||
| value: SSEBroadcasterRedisAdapter | ||
| value: exports.SSEBroadcasterRedisAdapter | ||
| }, | ||
| version: { | ||
| enumerable: true, | ||
| get: function () { | ||
| return require('./package.json').version | ||
| return require('./package.json').version; | ||
| } | ||
| } | ||
| }) | ||
| SSEBroadcasterRedisAdapter.prototype.onerror = function onerror (err) { | ||
| this.emit('error', err) | ||
| } | ||
| SSEBroadcasterRedisAdapter.prototype.onpmessage = function onpmessage (pattern, channel, message) { | ||
| var id = channel.substring(0, 24) | ||
| // we've got back our own message | ||
| if (this.id === id) | ||
| return | ||
| message = JSON.parse(message) | ||
| // do not re-emit this publish | ||
| // (and start an infinite ping-pong match) | ||
| message.emit = false | ||
| this.broadcaster.publish(channel.substring(30), message) | ||
| } | ||
| SSEBroadcasterRedisAdapter.prototype.onpublish = function onpublish (name, message) { | ||
| this.pub.publish(this.id + ':sseb:' + name, JSON.stringify(message)) | ||
| } | ||
| SSEBroadcasterRedisAdapter.prototype.onsubscribe = function onsubscribe (name) { | ||
| this.sub.psubscribe('*:sseb:' + name) | ||
| } | ||
| SSEBroadcasterRedisAdapter.prototype.onunsubscribe = function onunsubscribe (name) { | ||
| }); | ||
| exports.SSEBroadcasterRedisAdapter.prototype.onerror = function onerror(err) { | ||
| this.emit('error', err); | ||
| }; | ||
| exports.SSEBroadcasterRedisAdapter.prototype.onpmessage = function onpmessage(pattern, channel, message) { | ||
| var id = channel.substring(0, 24); | ||
| if (this.id === id) { | ||
| return; | ||
| } | ||
| message = JSON.parse(message); | ||
| message.emit = false; | ||
| this.broadcaster.publish(channel.substring(30), message); | ||
| }; | ||
| exports.SSEBroadcasterRedisAdapter.prototype.onpublish = function onpublish(name, message) { | ||
| this.pub.publish(this.id + ':sseb:' + name, JSON.stringify(message)); | ||
| }; | ||
| exports.SSEBroadcasterRedisAdapter.prototype.onsubscribe = function onsubscribe(name) { | ||
| this.sub.psubscribe('*:sseb:' + name); | ||
| }; | ||
| exports.SSEBroadcasterRedisAdapter.prototype.onunsubscribe = function onunsubscribe(name) { | ||
| if (!this.broadcaster.subscriberCount(name)) | ||
| this.sub.punsubscribe('*:sseb:' + name) | ||
| } | ||
| SSEBroadcasterRedisAdapter.prototype.quit = function quit () { | ||
| this.pub.quit() | ||
| this.sub.quit() | ||
| } | ||
| SSEBroadcasterRedisAdapter.prototype.unref = function unref () { | ||
| this.pub.unref() | ||
| this.sub.unref() | ||
| } | ||
| SSEBroadcasterRedisAdapter.prototype.end = function end (flush) { | ||
| this.pub.end(flush) | ||
| this.sub.end(flush) | ||
| } | ||
| this.sub.punsubscribe('*:sseb:' + name); | ||
| }; | ||
| exports.SSEBroadcasterRedisAdapter.prototype.quit = function quit() { | ||
| this.pub.quit(); | ||
| this.sub.quit(); | ||
| }; | ||
| exports.SSEBroadcasterRedisAdapter.prototype.unref = function unref() { | ||
| this.pub.unref(); | ||
| this.sub.unref(); | ||
| }; | ||
| exports.SSEBroadcasterRedisAdapter.prototype.end = function end(flush) { | ||
| this.pub.end(flush); | ||
| this.sub.end(flush); | ||
| }; |
| { | ||
| "name": "sse-broadcast-redis2", | ||
| "version": "0.1.1", | ||
| "version": "0.1.2", | ||
| "description": "Redis adapter for sse-broadcast clone with updated redis driver", | ||
@@ -36,2 +36,3 @@ "main": "index.js", | ||
| "devDependencies": { | ||
| "@types/node": "^17.0.40", | ||
| "coveralls": "^2.11.12", | ||
@@ -38,0 +39,0 @@ "istanbul": "^0.4.5", |
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
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 by26.04%
19582
- Number of package files
- increased by20%
12
- Lines of code
- increased by29.41%
418
Worsened metrics
- Dev dependency count
- increased by16.67%
7
No dependency changes