historical-deadletter-processor - npm Package Compare versions

Comparing version 2.2.1 to 2.3.0

lib/deadletter.processor.js

@@ -5,2 +5,4 @@ "use strict";
 
+var _get = function get(object, property, receiver) { if (object === null) object = Function.prototype; var desc = Object.getOwnPropertyDescriptor(object, property); if (desc === undefined) { var parent = Object.getPrototypeOf(object); if (parent === null) { return undefined; } else { return get(parent, property, receiver); } } else if ("value" in desc) { return desc.value; } else { var getter = desc.get; if (getter === undefined) { return undefined; } return getter.call(receiver); } };
+
 function _classCallCheck(instance, Constructor) { if (!(instance instanceof Constructor)) { throw new TypeError("Cannot call a class as a function"); } }
@@ -14,3 +16,15 @@
 (function () {
-  var AzureSearch, DeadletterProcessor, MaxRetriesProcessor, Promise, _, async, encode;
+  var AzureSearch,
+      DeadletterProcessor,
+      MaxRetriesProcessor,
+      Promise,
+      _,
+      async,
+      encode,
+      boundMethodCheck = function boundMethodCheck(instance, Constructor) {
+    if (!(instance instanceof Constructor)) {
+      throw new Error('Bound instance method accessed before binding');
+    }
+  },
+      indexOf = [].indexOf;
 
@@ -44,2 +58,3 @@ _ = require("lodash");
 
+      _this._shouldRetry_ = _this._shouldRetry_.bind(_this);
       connection = opts.connection;
@@ -51,2 +66,3 @@ _this.app = opts.app;
       _this.index = _opts$index === undefined ? "errors" : _opts$index;
+      _this.nonRetryable = opts.nonRetryable;
 
@@ -62,2 +78,9 @@ _this.client = _this._buildClient(connection);
     }, {
+      key: "_shouldRetry_",
+      value: function _shouldRetry_(notification, err) {
+        var ref, ref1, ref2;
+        boundMethodCheck(this, DeadletterProcessor);
+        return _get(DeadletterProcessor.prototype.__proto__ || Object.getPrototypeOf(DeadletterProcessor.prototype), "_shouldRetry_", this).call(this, notification, err) && (ref = err != null ? (ref1 = err.detail) != null ? (ref2 = ref1.response) != null ? ref2.statusCode : void 0 : void 0 : void 0, indexOf.call(this.nonRetryable, ref) < 0);
+      }
+    }, {
       key: "_sanitizeError_",
@@ -64,0 +87,0 @@ value: function _sanitizeError_(err) {

package.json

 {
   "name": "historical-deadletter-processor",
-  "version": "2.2.1",
+  "version": "2.3.0",
   "description": "historical-deadletter-processor",
@@ -5,0 +5,0 @@ "main": "index.js",

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

14623

increased by10.56%

Lines of code

245

increased by10.86%

No dependency changes