notification-processor - npm Package Compare versions

Comparing version 4.3.0 to 4.4.0

lib/exceptions/non.retryable.js

@@ -5,3 +5,3 @@ "use strict";
 
-// Generated by CoffeeScript 2.3.2
+// Generated by CoffeeScript 2.5.1
 (function () {
@@ -8,0 +8,0 @@ var NonRetryable;

lib/index.js

 "use strict";
 
-// Generated by CoffeeScript 2.3.2
+// Generated by CoffeeScript 2.5.1
 (function () {
@@ -5,0 +5,0 @@ module.exports = {

lib/observers/deadLetterSucceeded.observer.js

@@ -11,3 +11,3 @@ "use strict";
 
-// Generated by CoffeeScript 2.3.2
+// Generated by CoffeeScript 2.5.1
 (function () {
@@ -14,0 +14,0 @@ var DeadLetterSucceededObserver,

lib/observers/delay.levels.js

 "use strict";
 
-// Generated by CoffeeScript 2.3.2
+// Generated by CoffeeScript 2.5.1
 (function () {
@@ -5,0 +5,0 @@ var convert;

lib/observers/delay.observer.js

@@ -11,3 +11,3 @@ "use strict";
 
-// Generated by CoffeeScript 2.3.2
+// Generated by CoffeeScript 2.5.1
 (function () {
@@ -14,0 +14,0 @@ var DelayObserver,

lib/observers/didLastRetry.observer.js

@@ -11,3 +11,3 @@ "use strict";
 
-// Generated by CoffeeScript 2.3.2
+// Generated by CoffeeScript 2.5.1
 (function () {
@@ -14,0 +14,0 @@ var DidLastRetry,

lib/observers/incidentsApi.observer.js

@@ -7,3 +7,3 @@ "use strict";
 
-// Generated by CoffeeScript 2.3.2
+// Generated by CoffeeScript 2.5.1
 (function () {
@@ -10,0 +10,0 @@ var IncidentsApiObserver, ServiceBusClient, _, debug, encode;

lib/observers/logger.observer.js

 "use strict";
 
-// Generated by CoffeeScript 2.3.2
+// Generated by CoffeeScript 2.5.1
 (function () {
@@ -5,0 +5,0 @@ var errorToJson;

lib/observers/redis.observer.js

@@ -7,3 +7,3 @@ "use strict";
 
-// Generated by CoffeeScript 2.3.2
+// Generated by CoffeeScript 2.5.1
 (function () {
@@ -10,0 +10,0 @@ var Promise, Redis, RedisObserver, _;

lib/processor.builder.js

@@ -7,3 +7,3 @@ "use strict";
 
-// Generated by CoffeeScript 2.3.2
+// Generated by CoffeeScript 2.5.1
 (function () {
@@ -10,0 +10,0 @@ var MeliSender, Processor, ProcessorBuilder, ProductecaSender, QueueSource, ServiceBusSource, UnknownSource, _, logger;

lib/processor.js

@@ -11,3 +11,3 @@ "use strict";
 
-// Generated by CoffeeScript 2.3.2
+// Generated by CoffeeScript 2.5.1
 (function () {
@@ -14,0 +14,0 @@ var ENABLE_EVENTS,

lib/processors/deadletter.processor.js

@@ -11,3 +11,3 @@ "use strict";
 
-// Generated by CoffeeScript 2.3.2
+// Generated by CoffeeScript 2.5.1
 (function () {
@@ -14,0 +14,0 @@ var DeadletterProcessor, MaxRetriesProcessor, NonRetryable;

lib/processors/job/index.js

 "use strict";
 
-// Generated by CoffeeScript 2.3.2
+// Generated by CoffeeScript 2.5.1
 (function () {
@@ -5,0 +5,0 @@ var JobProcessor, RequestProcessor, _;

lib/processors/job/job.processor.js

@@ -13,3 +13,3 @@ "use strict";
 
-// Generated by CoffeeScript 2.3.2
+// Generated by CoffeeScript 2.5.1
 (function () {
@@ -79,3 +79,3 @@ var JobProcessor,
         boundMethodCheck(this, JobProcessor);
-        return _.pick(err, ["statusCode", "error"]);
+        return _.pick(err, ["message", "type", "detail.request"]);
       }
@@ -82,0 +82,0 @@ }, {

lib/processors/job/notification.api.js

@@ -7,3 +7,3 @@ "use strict";
 
-// Generated by CoffeeScript 2.3.2
+// Generated by CoffeeScript 2.5.1
 (function () {
@@ -10,0 +10,0 @@ var NotificationsApi, _, request, retry;

lib/processors/maxRetries.processor.js

@@ -7,3 +7,3 @@ "use strict";
 
-// Generated by CoffeeScript 2.3.2
+// Generated by CoffeeScript 2.5.1
 (function () {
@@ -10,0 +10,0 @@ var MaxRetriesProcessor;

lib/processors/request.async.processor.js

 "use strict";
 
-// Generated by CoffeeScript 2.3.2
+// Generated by CoffeeScript 2.5.1
 (function () {
@@ -5,0 +5,0 @@ var RequestProcessor, _, _normalizeHeaders, builderRequest;

lib/processors/request.processor.js

 "use strict";
 
-// Generated by CoffeeScript 2.3.2
+// Generated by CoffeeScript 2.5.1
 (function () {
-  var MESSAGE_PROPERTIES, NonRetryableError, Promise, RequestError, StatusCodeError, _, _safeParse, _type, httpStatus, request;
+  var MESSAGE_PROPERTIES, NonRetryableError, Promise, RequestError, StatusCodeError, _, __isIncludedInStatusesError, _safeParse, _type, errorConditions, httpStatus, request;
 
@@ -41,2 +41,23 @@ _ = require("lodash");
 
+  errorConditions = {
+    client: function client(it) {
+      return it >= 400 && it < 500;
+    },
+    server: function server(it) {
+      return it >= 500;
+    }
+  };
+
+  __isIncludedInStatusesError = function __isIncludedInStatusesError(conditions) {
+    return function (err) {
+      var statusCode;
+      statusCode = _.get(err, "detail.response.statusCode");
+      return _(conditions).map(function (it) {
+        return _.get(errorConditions, it, _.partial(_.isEqual, it));
+      }).some(function (condition) {
+        return condition(statusCode);
+      });
+    };
+  };
+
   module.exports = function (requestGenerator) {
@@ -50,8 +71,2 @@ var _ref = arguments.length > 1 && arguments[1] !== undefined ? arguments[1] : {},
     return function (notification) {
-      var __isIncludedInStatusesError;
-      __isIncludedInStatusesError = function __isIncludedInStatusesError(statuses) {
-        return function (err) {
-          return _.includes(statuses, _.get(err, "detail.response.statusCode"));
-        };
-      };
       return Promise.method(requestGenerator)(notification).then(function (options) {
@@ -58,0 +73,0 @@ return request(options).promise().catch(RequestError, function (_ref2) {

lib/senders/index.js

 "use strict";
 
-// Generated by CoffeeScript 2.3.2
+// Generated by CoffeeScript 2.5.1
 (function () {
@@ -5,0 +5,0 @@ module.exports = {

lib/senders/meli.sender.js

 "use strict";
 
-// Generated by CoffeeScript 2.3.2
+// Generated by CoffeeScript 2.5.1
 (function () {
@@ -5,0 +5,0 @@ module.exports = {

lib/senders/producteca.sender.js

 "use strict";
 
-// Generated by CoffeeScript 2.3.2
+// Generated by CoffeeScript 2.5.1
 (function () {
@@ -5,0 +5,0 @@ module.exports = {

lib/services/redis.js

 "use strict";
 
-// Generated by CoffeeScript 2.3.2
+// Generated by CoffeeScript 2.5.1
 (function () {
@@ -5,0 +5,0 @@ var Promise, redis;

lib/sources/index.js

 "use strict";
 
-// Generated by CoffeeScript 2.3.2
+// Generated by CoffeeScript 2.5.1
 (function () {
@@ -5,0 +5,0 @@ module.exports = {

lib/sources/queue.source.js

 "use strict";
 
-// Generated by CoffeeScript 2.3.2
+// Generated by CoffeeScript 2.5.1
 (function () {
@@ -5,0 +5,0 @@ var DeadLetterSucceeded, DelayObserver, DidLastRetry, _, create;

lib/sources/service.bus.source.js

 "use strict";
 
-// Generated by CoffeeScript 2.3.2
+// Generated by CoffeeScript 2.5.1
 (function () {
@@ -5,0 +5,0 @@ var DeadLetterSucceeded, DelayObserver, DidLastRetry, _, create;

lib/sources/table.source.js

 "use strict";
 
-// Generated by CoffeeScript 2.3.2
+// Generated by CoffeeScript 2.5.1
 (function () {
@@ -5,0 +5,0 @@ var _;

lib/sources/unknown.source.js

 "use strict";
 
-// Generated by CoffeeScript 2.3.2
+// Generated by CoffeeScript 2.5.1
 (function () {
@@ -5,0 +5,0 @@ var _;

lib/specHelpers/fixture.js

 "use strict";
 
-// Generated by CoffeeScript 2.3.2
+// Generated by CoffeeScript 2.5.1
 (function () {
@@ -5,0 +5,0 @@ var _, notification, redis;

lib/specHelpers/redis.observer.mock.js

@@ -7,3 +7,3 @@ "use strict";
 
-// Generated by CoffeeScript 2.3.2
+// Generated by CoffeeScript 2.5.1
 (function () {
@@ -10,0 +10,0 @@ var MockRedis, MockRedisClient, Promise, _, proxyquire, sinon, stub;

package.json

 {
   "name": "notification-processor",
-  "version": "4.3.0",
+  "version": "4.4.0",
   "description": "notification-processor",
@@ -5,0 +5,0 @@ "main": "index.js",

No alert changes

Improved metrics

Total package byte prevSize

64639

increased by0.59%

Lines of code

1390

increased by0.94%

No dependency changes