prepare 5.10.3 release (#171)

Author: LaunchDarklyCI

event_processor.js

@@ -1,5 +1,6 @@
 const LRUCache = require('lrucache');
 const request = require('request');
+const uuidv4 = require('uuid/v4');
 const EventSummarizer = require('./event_summarizer');
 const UserFilter = require('./user_filter');
 const errors = require('./errors');
@@ -188,16 +189,16 @@ function EventProcessor(sdkKey, config, errorReporter) {
 
       config.logger.debug('Flushing %d events', worklist.length);
 
-      tryPostingEvents(worklist, resolve, reject, true);
+      tryPostingEvents(worklist, uuidv4(), resolve, reject, true);
     }), callback);
   };
 
-  function tryPostingEvents(events, resolve, reject, canRetry) {
+  function tryPostingEvents(events, payloadId, resolve, reject, canRetry) {
     const retryOrReject = err => {
       if (canRetry) {
         config.logger && config.logger.warn('Will retry posting events after 1 second');
         setTimeout(() => {
-          tryPostingEvents(events, resolve, reject, false);
+          tryPostingEvents(events, payloadId, resolve, reject, false);
         }, 1000);
       } else {
         reject(err);
@@ -210,7 +211,8 @@ function EventProcessor(sdkKey, config, errorReporter) {
       headers: {
         'Authorization': sdkKey,
         'User-Agent': config.userAgent,
-        'X-LaunchDarkly-Event-Schema': '3'
+        'X-LaunchDarkly-Event-Schema': '3',
+        'X-LaunchDarkly-Payload-ID': payloadId
       },
       json: true,
       body: events,

package-lock.json

@@ -34,6 +34,7 @@
     "request-etag": "^2.0.3",
     "semver": "^6.3.0",
     "tunnel": "0.0.6",
+    "uuid": "^3.3.3",
     "winston": "2.4.1",
     "yaml": "1.0.1"
   },

package.json

@@ -483,6 +483,24 @@ describe('EventProcessor', () => {
     });
   }));
 
+  it('sends unique payload IDs', eventsServerTest(async s => {
+    await withEventProcessor(defaultConfig, s, async ep => {
+      const e = { kind: 'identify', creationDate: 1000, user: user };
+      ep.sendEvent(e);
+      await ep.flush();
+      ep.sendEvent(e);
+      await ep.flush();
+
+      const req0 = await s.nextRequest();
+      const req1 = await s.nextRequest();
+      const id0 = req0.headers['x-launchdarkly-payload-id'];
+      const id1 = req1.headers['x-launchdarkly-payload-id'];
+      expect(id0).toBeTruthy();
+      expect(id1).toBeTruthy();
+      expect(id0).not.toEqual(id1);
+    });
+  }));
+
   function verifyUnrecoverableHttpError(status) {
     return eventsServerTest(async s => {
       s.forMethodAndPath('post', '/bulk', TestHttpHandlers.respond(status));
@@ -510,13 +528,18 @@ describe('EventProcessor', () => {
         await expect(ep.flush()).rejects.toThrow('error ' + status);
 
         expect(s.requestCount()).toEqual(2);
-        await s.nextRequest();
-        await s.nextRequest();
+        const req0 = await s.nextRequest();
+        const req1 = await s.nextRequest();
+        expect(req0.body).toEqual(req1.body);
+        const id0 = req0.headers['x-launchdarkly-payload-id'];
+        expect(req1.headers['x-launchdarkly-payload-id']).toEqual(id0);
 
         s.forMethodAndPath('post', '/bulk', TestHttpHandlers.respond(200));
         ep.sendEvent(e);
         await ep.flush();
         expect(s.requestCount()).toEqual(3);
+        const req2 = await s.nextRequest();
+        expect(req2.headers['x-launchdarkly-payload-id']).not.toEqual(id0);
       });
     });
   }