nats-hemera - npm Package Compare versions

Comparing version 0.1.46 to 0.1.47

lib/constants.js

@@ -25,3 +25,5 @@ /*!
   PAYLOAD_VALIDATION_ERROR: 'Invalid payload',
-  ADD_ADDED: 'ADD - ADDED'
+  ADD_ADDED: 'ADD - ADDED',
+  BUSINESS_ERROR: 'Business error',
+  FATAL_ERROR: 'Fatal error'
 }

lib/index.js

@@ -78,3 +78,5 @@ /*!
       if (this.plugins[params.attributes.name]) {
-        let error = new Errors.HemeraError(Constants.PLUGIN_ALREADY_IN_USE)
+        let error = new Errors.HemeraError(Constants.PLUGIN_ALREADY_IN_USE, {
+          plugin: params.attributes.name
+        })
         this.log.error(error)
@@ -213,3 +215,5 @@ throw (error)
 
-          let error = new Errors.ParseError(Constants.PAYLOAD_PARSING_ERROR).causedBy(result.error)
+          let error = new Errors.ParseError(Constants.PAYLOAD_PARSING_ERROR, {
+            topic
+          }).causedBy(result.error)
 
@@ -219,3 +223,4 @@ return this.send(replyTo, ctx.reply(error))
 
-        let actMeta = this.catalog.lookup(result.value.pattern)
+        let pattern = result.value.pattern
+        let actMeta = this.catalog.lookup(pattern)
 
@@ -234,3 +239,5 @@ //Check if a handler is registered with this pattern
 
-                let payloadError = new Errors.PayloadValidationError(Constants.PAYLOAD_VALIDATION_ERROR).causedBy(err)
+                let payloadError = new Errors.PayloadValidationError(Constants.PAYLOAD_VALIDATION_ERROR, {
+                  pattern
+                }).causedBy(err)
 
@@ -248,3 +255,5 @@ //Send message
 
-                  let businessError = new Errors.BusinessError(Constants.IMPLEMENTATION_ERROR).causedBy(err)
+                  let businessError = new Errors.BusinessError(Constants.IMPLEMENTATION_ERROR, {
+                    pattern
+                  }).causedBy(err)
 
@@ -263,3 +272,5 @@ return this.send(replyTo, ctx.reply(businessError))
 
-            let error = new Errors.ImplementationError(Constants.IMPLEMENTATION_ERROR).causedBy(err)
+            let error = new Errors.ImplementationError(Constants.IMPLEMENTATION_ERROR, {
+              pattern
+            }).causedBy(err)
 
@@ -284,3 +295,5 @@ //Send error back to callee
 
-          let error = new Errors.PatternNotFound(Constants.PATTERN_NOT_FOUND)
+          let error = new Errors.PatternNotFound(Constants.PATTERN_NOT_FOUND, {
+            pattern
+          })
 
@@ -311,3 +324,5 @@ //Send error back to callee
 
-        let error = new Errors.HemeraError(Constants.NO_TOPIC_TO_SUBSCRIBE)
+        let error = new Errors.HemeraError(Constants.NO_TOPIC_TO_SUBSCRIBE, {
+          pattern
+        })
         this.log.error(error)
@@ -319,3 +334,5 @@ throw (error)
 
-        let error = new Errors.HemeraError(Constants.MISSING_IMPLEMENTATION)
+        let error = new Errors.HemeraError(Constants.MISSING_IMPLEMENTATION, {
+          pattern
+        })
         this.log.error(error)
@@ -349,3 +366,5 @@ throw (error)
 
-        let error = new Errors.HemeraError(Constants.PATTERN_ALREADY_IN_USE)
+        let error = new Errors.HemeraError(Constants.PATTERN_ALREADY_IN_USE, {
+          pattern
+        })
         this.log.error(error)
@@ -377,3 +396,5 @@ throw (error)
 
-        let error = new Errors.HemeraError(Constants.NO_TOPIC_TO_REQUEST)
+        let error = new Errors.HemeraError(Constants.NO_TOPIC_TO_REQUEST, {
+          pattern
+        })
         this.log.error(error)
@@ -418,3 +439,5 @@ throw (error)
 
-            let error = new Errors.ParseError(Constants.PAYLOAD_PARSING_ERROR).causedBy(msg.error)
+            let error = new Errors.ParseError(Constants.PAYLOAD_PARSING_ERROR, {
+              pattern: cleanPattern
+            }).causedBy(msg.error)
             this.log.error(error)
@@ -439,3 +462,5 @@
 
-              let error = new Errors.BusinessError().causedBy(Errio.parse(msg.value.error))
+              let error = new Errors.BusinessError(Constants.BUSINESS_ERROR, {
+                pattern: cleanPattern
+              }).causedBy(Errio.parse(msg.value.error))
               this.log.error(error)
@@ -452,3 +477,5 @@
 
-          let error = new Errors.FatalError().causedBy(err)
+          let error = new Errors.FatalError(Constants.FATAL_ERROR, {
+            pattern: cleanPattern
+          }).causedBy(err)
           this.log.fatal(error)
@@ -483,4 +510,6 @@
 
-        let error = new Errors.TimeoutError(Constants.ACT_TIMEOUT_ERROR)
-        this.log.error(error, pattern)
+        let error = new Errors.TimeoutError(Constants.ACT_TIMEOUT_ERROR, {
+          pattern
+        })
+        this.log.error(error)
 
@@ -494,3 +523,5 @@ if (typeof cb === 'function') {
 
-            let error = new Errors.FatalError().causedBy(err)
+            let error = new Errors.FatalError(Constants.FATAL_ERROR, {
+              pattern
+            }).causedBy(err)
             this.log.fatal(error)
@@ -497,0 +528,0 @@

package.json

 {
   "name": "nats-hemera",
   "author": "Dustin Deus (https://github.com/StarpTech)",
-  "version": "0.1.46",
+  "version": "0.1.47",
   "main": "index.js",
@@ -6,0 +6,0 @@ "homepage": "https://hemerajs.github.io/hemera/",

No alert changes

Improved metrics

Total package byte prevSize

43755

1.86%

Lines of code

819

4.2%

No dependency changes