wingbot-mongodb - npm Package Compare versions

Comparing version 3.2.1 to 3.2.2

.nyc_output/processinfo/index.json

@@ -1,1 +0,1 @@
-{"processes":{"6a7ed916-683a-43fd-8624-795a77e80a4a":{"parent":null,"children":[]}},"files":{"/Users/david/Development/wingbot-mongodb/src/BaseStorage.js":["6a7ed916-683a-43fd-8624-795a77e80a4a"],"/Users/david/Development/wingbot-mongodb/src/defaultLogger.js":["6a7ed916-683a-43fd-8624-795a77e80a4a"],"/Users/david/Development/wingbot-mongodb/src/AttachmentCache.js":["6a7ed916-683a-43fd-8624-795a77e80a4a"],"/Users/david/Development/wingbot-mongodb/src/AuditLogStorage.js":["6a7ed916-683a-43fd-8624-795a77e80a4a"],"/Users/david/Development/wingbot-mongodb/src/BotConfigStorage.js":["6a7ed916-683a-43fd-8624-795a77e80a4a"],"/Users/david/Development/wingbot-mongodb/src/BotTokenStorage.js":["6a7ed916-683a-43fd-8624-795a77e80a4a"],"/Users/david/Development/wingbot-mongodb/src/tokenFactory.js":["6a7ed916-683a-43fd-8624-795a77e80a4a"],"/Users/david/Development/wingbot-mongodb/src/ChatLogStorage.js":["6a7ed916-683a-43fd-8624-795a77e80a4a"],"/Users/david/Development/wingbot-mongodb/src/NotificationsStorage.js":["6a7ed916-683a-43fd-8624-795a77e80a4a"],"/Users/david/Development/wingbot-mongodb/src/StateStorage.js":["6a7ed916-683a-43fd-8624-795a77e80a4a"]},"externalIds":{}}
+{"processes":{"98a862df-b2a1-4d14-9176-6b0bada108f7":{"parent":null,"children":[]}},"files":{"/Users/david/Development/wingbot-mongodb/src/BaseStorage.js":["98a862df-b2a1-4d14-9176-6b0bada108f7"],"/Users/david/Development/wingbot-mongodb/src/defaultLogger.js":["98a862df-b2a1-4d14-9176-6b0bada108f7"],"/Users/david/Development/wingbot-mongodb/src/AttachmentCache.js":["98a862df-b2a1-4d14-9176-6b0bada108f7"],"/Users/david/Development/wingbot-mongodb/src/AuditLogStorage.js":["98a862df-b2a1-4d14-9176-6b0bada108f7"],"/Users/david/Development/wingbot-mongodb/src/BotConfigStorage.js":["98a862df-b2a1-4d14-9176-6b0bada108f7"],"/Users/david/Development/wingbot-mongodb/src/BotTokenStorage.js":["98a862df-b2a1-4d14-9176-6b0bada108f7"],"/Users/david/Development/wingbot-mongodb/src/tokenFactory.js":["98a862df-b2a1-4d14-9176-6b0bada108f7"],"/Users/david/Development/wingbot-mongodb/src/ChatLogStorage.js":["98a862df-b2a1-4d14-9176-6b0bada108f7"],"/Users/david/Development/wingbot-mongodb/src/NotificationsStorage.js":["98a862df-b2a1-4d14-9176-6b0bada108f7"],"/Users/david/Development/wingbot-mongodb/src/StateStorage.js":["98a862df-b2a1-4d14-9176-6b0bada108f7"]},"externalIds":{}}

package.json

 {
   "name": "wingbot-mongodb",
-  "version": "3.2.1",
+  "version": "3.2.2",
   "description": "MongoDB storage for wingbot.ai",
@@ -5,0 +5,0 @@ "main": "src/main.js",

src/NotificationsStorage.js

@@ -306,3 +306,3 @@ /**
             .reduce((arr, {
-                campaignId, senderId, pageId, sent
+                campaignId, senderId, pageId, sent, enqueue
             }, i) => {
@@ -314,2 +314,3 @@ if (typeof res.upsertedIds[i] !== 'undefined') {
                     i,
+                    enqueue,
                     filter: {
@@ -326,3 +327,3 @@ campaignId, senderId, pageId, sent
             await Promise.all(findMissingIds
-                .map(({ filter, i }) => c.findOne(filter, {
+                .map(({ filter, i, enqueue }) => c.findOne(filter, {
                     projection: {
@@ -333,13 +334,21 @@ _id: 1, insEnqueue: 1, enqueue: 1, ups: 1
                     .then((found) => {
-                        const id = typeof found._id === 'string'
-                            ? found._id
-                            : found._id.toHexString();
-                        missingIds.set(i, {
-                            id,
-                            insEnqueue: found.insEnqueue,
-                            enqueue: found.insEnqueue === found.enqueue
-                                && found.enqueue !== MAX_TS && found.ups !== 1
-                                ? found.enqueue + 1
-                                : found.enqueue
-                        });
+                        if (!found) { // race condition occurred
+                            missingIds.set(i, {
+                                id: null,
+                                insEnqueue: -1,
+                                enqueue
+                            });
+                        } else {
+                            const id = typeof found._id === 'string'
+                                ? found._id
+                                : found._id.toHexString();
+                            missingIds.set(i, {
+                                id,
+                                insEnqueue: found.insEnqueue,
+                                enqueue: found.insEnqueue === found.enqueue
+                                    && found.enqueue !== MAX_TS && found.ups !== 1
+                                    ? found.enqueue + 1
+                                    : found.enqueue
+                            });
+                        }
                     })));
@@ -346,0 +355,0 @@ }

No alert changes

Improved metrics

Total package byte prevSize

261380

increased by0.33%

Lines of code

2325

increased by0.39%

No dependency changes