worksmith_rascal
Advanced tools
Comparing version 0.2.3 to 0.2.4
{ | ||
"name": "worksmith_rascal", | ||
"version": "0.2.3", | ||
"version": "0.2.4", | ||
"description": "Rascal activites for worksmith", | ||
"main": "index.js", | ||
"scripts": { | ||
"test": "mocha --recursive tests", | ||
"test": "mocha --exit --recursive tests", | ||
"prepush": "npm test" | ||
@@ -24,13 +24,12 @@ }, | ||
"dependencies": { | ||
"debug": "^2.2.0", | ||
"lodash": "^3.9.3", | ||
"rascal": "^0.8.0" | ||
"debug": "^4.1.1", | ||
"lodash.assignin": "^4.2.0", | ||
"lodash.defaults": "^4.2.0" | ||
}, | ||
"devDependencies": { | ||
"gulp": "^3.9.0", | ||
"gulp-mocha": "^2.1.1", | ||
"husky": "^0.8.1", | ||
"mocha": "^2.2.5", | ||
"worksmith": "^0.1.5" | ||
"husky": "^1.3.1", | ||
"mocha": "^6.0.2", | ||
"rascal": "^4.2.3", | ||
"worksmith": "^1.0.0" | ||
} | ||
} |
'use strict' | ||
var _ = require('lodash') | ||
var assignIn = require('lodash.assignin') | ||
@@ -14,3 +14,3 @@ module.exports = function define(node) { | ||
logger[level || 'info'](message, _.extend({ | ||
logger[level || 'info'](message, assignIn({ | ||
messageId: context.message.properties.messageId, | ||
@@ -24,2 +24,2 @@ routingKey: context.message.fields.routingKey | ||
} | ||
} | ||
} |
@@ -1,2 +0,2 @@ | ||
var _ = require('lodash') | ||
var defaults = require('lodash.defaults') | ||
@@ -12,3 +12,3 @@ module.exports = function(node) { | ||
broker = broker || context.broker | ||
options = _.defaults({}, { routingKey: routingKey }, options) | ||
options = defaults({}, { routingKey: routingKey }, options) | ||
@@ -26,2 +26,2 @@ broker.publish(publicationId, payload, options, function(err, publication) { | ||
} | ||
} | ||
} |
@@ -1,2 +0,3 @@ | ||
var _ = require('lodash') | ||
var defaults = require('lodash.defaults') | ||
//An activity to receive exactly x number of messages | ||
@@ -13,8 +14,8 @@ //Activity 'subscribe' will be the one that listens on a subscription for indefinite time | ||
var timeOutToken | ||
options = _.defaults({}, options, {prefetch:1 }) | ||
options = defaults({}, options, {prefetch:1 }) | ||
broker = broker || context.broker | ||
var _receiveOne = function(m, c, an) { | ||
clearTimeout(timeOutToken) | ||
_receiveOne = function(m, c, an) { | ||
_receiveOne = function(m, c, an) { | ||
an({}, {strategy:'republish'}) | ||
@@ -25,8 +26,8 @@ } | ||
} | ||
var receiveOne = function(message, content, ackNack) { | ||
_receiveOne(message, content, ackNack) | ||
} | ||
broker.subscribe(subscription, options, function(err, subscription) { | ||
@@ -48,2 +49,2 @@ if (timeOut) { | ||
} | ||
} | ||
} |
@@ -149,2 +149,2 @@ 'use strict' | ||
}) | ||
}) | ||
}) |
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
New author
Supply chain riskA new npm collaborator published a version of the package for the first time. New collaborators are usually benign additions to a project, but do indicate a change to the security surface area of a package.
Found 1 instance in 1 package
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
Environment variable access
Supply chain riskPackage accesses environment variables, which may be a sign of credential stuffing or data theft.
Found 1 instance in 1 package
4
1
13961
11
298
1
+ Addedlodash.assignin@^4.2.0
+ Addedlodash.defaults@^4.2.0
+ Addeddebug@4.4.0(transitive)
+ Addedlodash.assignin@4.2.0(transitive)
+ Addedlodash.defaults@4.2.0(transitive)
+ Addedms@2.1.3(transitive)
- Removedlodash@^3.9.3
- Removedrascal@^0.8.0
- Removed@sailshq/lodash@3.10.6(transitive)
- Removedamqplib@0.3.2(transitive)
- Removedasync@0.9.2(transitive)
- Removedbitsyntax@0.0.4(transitive)
- Removedbuffer-more-ints@0.0.2(transitive)
- Removedcore-util-is@1.0.3(transitive)
- Removeddebug@2.6.9(transitive)
- Removedforward-emitter@0.0.1(transitive)
- Removedindividual@2.0.0(transitive)
- Removedinherits@2.0.4(transitive)
- Removedisarray@0.0.1(transitive)
- Removedlodash@3.10.1(transitive)
- Removedmerge-defaults@0.2.2(transitive)
- Removedms@2.0.0(transitive)
- Removednode-uuid@1.4.8(transitive)
- Removedrascal@0.8.1(transitive)
- Removedreadable-stream@1.1.14(transitive)
- Removedrust-result@1.0.0(transitive)
- Removedsafe-json-parse@4.0.0(transitive)
- Removedstring_decoder@0.10.31(transitive)
- Removedwhen@3.6.4(transitive)
- Removedxregexp@2.0.0(transitive)
Updateddebug@^4.1.1