Huge News!Announcing our $40M Series B led by Abstract Ventures.Learn More
Socket
Sign inDemoInstall
Socket

worksmith_rascal

Package Overview
Dependencies
Maintainers
1
Versions
4
Alerts
File Explorer

Advanced tools

Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

worksmith_rascal - npm Package Compare versions

Comparing version 0.2.3 to 0.2.4

19

package.json
{
"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'

})
})
})
SocketSocket SOC 2 Logo

Product

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

Packages

npm

Stay in touch

Get open source security insights delivered straight into your inbox.


  • Terms
  • Privacy
  • Security

Made with ⚡️ by Socket Inc