notification-processor
Advanced tools
Comparing version 1.6.0 to 1.6.1
@@ -11,18 +11,27 @@ (function() { | ||
(ref = arg.context, log = ref.log), notification = arg.notification; | ||
return log("A new message has been received", notification); | ||
return log.info("A new message has been received", { | ||
notification: notification | ||
}); | ||
}); | ||
observable.on("successful", function(arg) { | ||
var log; | ||
log = arg.context.log; | ||
return log("Process successful"); | ||
var log, notification, ref; | ||
(ref = arg.context, log = ref.log), notification = arg.notification; | ||
return log.info("Process successful", { | ||
notification: notification | ||
}); | ||
}); | ||
observable.on("unsuccessful", function(arg) { | ||
var error, log, ref; | ||
(ref = arg.context, log = ref.log), error = arg.error; | ||
return log("Process unsuccessful", errorToJson(error)); | ||
var error, log, notification, ref; | ||
(ref = arg.context, log = ref.log), notification = arg.notification, error = arg.error; | ||
return log.error("Process unsuccessful", { | ||
notification: notification, | ||
error: errorToJson(error) | ||
}); | ||
}); | ||
observable.on("finished", function(arg) { | ||
var log; | ||
log = arg.context.log; | ||
return log("Process finished"); | ||
var log, notification, ref; | ||
(ref = arg.context, log = ref.log), notification = arg.notification; | ||
return log.info("Process finished", { | ||
notification: notification | ||
}); | ||
}); | ||
@@ -32,3 +41,5 @@ return observable.on("ignored", function(arg) { | ||
(ref = arg.context, log = ref.log), notification = arg.notification; | ||
return log("Message ignored", notification); | ||
return log.verbose("Message ignored", { | ||
notification: notification | ||
}); | ||
}); | ||
@@ -35,0 +46,0 @@ } |
{ | ||
"name": "notification-processor", | ||
"version": "1.6.0", | ||
"version": "1.6.1", | ||
"description": "notification-processor", | ||
@@ -5,0 +5,0 @@ "main": "index.js", |
Sorry, the diff of this file is not supported yet
1281
112779