You're Invited:Meet the Socket Team at BlackHat and DEF CON in Las Vegas, Aug 7-8.RSVP
Socket
Socket
Sign inDemoInstall

bossman

Package Overview
Dependencies
4
Maintainers
1
Versions
5
Alerts
File Explorer

Advanced tools

Install Socket

Detect and block malicious and high-risk dependencies

Install

Comparing version 1.0.1 to 1.0.2

4

lib/__tests__/Bossman.test.js

@@ -36,3 +36,5 @@ /* eslint-env jest */

beforeEach(function () {
boss = new Bossman();
boss = new Bossman({
db: 3
});
});

@@ -39,0 +41,0 @@

@@ -42,3 +42,4 @@ Object.defineProperty(exports, "__esModule", {

this.dbNumber = this.connection && this.connection.db || 0;
var DB_NUMBER = connection && connection.db || 0;
this.prefix = prefix;

@@ -48,6 +49,3 @@ this.ttl = ttl;

this.client = new _ioredis2['default'](connection);
this.subscriber = new _ioredis2['default'](Object.assign({}, connection, {
// Force our db to be 0 for the subscriber:
db: 0
}));
this.subscriber = new _ioredis2['default'](connection);
this.redlock = new _redlock2['default']([this.client], { retryCount: 0 });

@@ -58,6 +56,6 @@

// this.subscriber.config('SET', 'notify-keyspace-events', 'Ex');
this.subscriber.config('SET', 'notify-keyspace-events', 'Ex');
// Subscribe to expiring keys on the jobs DB:
this.subscriber.subscribe('__keyevent@' + String(this.dbNumber) + '__:expired');
this.subscriber.subscribe('__keyevent@' + String(DB_NUMBER) + '__:expired');
this.subscriber.on('message', function (channel, message) {

@@ -64,0 +62,0 @@ // Check to make sure that the message is a job run request:

{
"name": "bossman",
"version": "1.0.1",
"version": "1.0.2",
"description": "Distributed job scheduling in node, based on redis.",

@@ -37,3 +37,10 @@ "main": "lib/index.js",

"throwback": "^1.1.1"
},
"jest": {
"mocksPattern": "src/(?:[\\/]|^)__mocks__[\\/]",
"testPathIgnorePatterns": [
"/node_modules/",
"<rootDir>/lib/"
]
}
}
SocketSocket SOC 2 Logo

Product

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

Packages

Stay in touch

Get open source security insights delivered straight into your inbox.


  • Terms
  • Privacy
  • Security

Made with ⚡️ by Socket Inc