Merge pull request #31 from signalfx/fixLastSeenDataBatchTime

kchengsf · web-flow · commit 586018016f94 · 2017-03-31T16:51:19.000-07:00
Fix last seen data batch time
diff --git a/lib/client/signalflow/message_router.js b/lib/client/signalflow/message_router.js
@@ -23,12 +23,12 @@ function getRoutedMessageHandler(params, onMessage, onError, isRetryPatchMode) {
     var errorOccurred = false;
     var basisData = dataArray[0];
     var expectedTimeStamp = basisData.logicalTimestampMs;
+    lastSeenDataBatchTime = expectedTimeStamp;
     dataArray.slice(1).forEach(function (batch) {
       if (batch.logicalTimestampMs !== expectedTimeStamp) {
         errorOccurred = true;
       } else {
         basisData.data = basisData.data.concat(batch.data);
-        lastSeenDataBatchTime = batch.logicalTimestampMs;
       }
     });
 
diff --git a/package.json b/package.json
@@ -1,6 +1,6 @@
 {
   "name": "signalfx",
-  "version": "4.0.22",
+  "version": "4.0.23",
   "description": "Node.js client library for SignalFx",
   "homepage": "https://signalfx.com",
   "repository": "https://github.com/signalfx/signalfx-nodejs",

Original file line number	Diff line number	Diff line change
`@@ -1,6 +1,6 @@`
`1`	`1`	`{`
`2`	`2`	`"name": "signalfx",`
`3`		`- "version": "4.0.22",`
	`3`	`+ "version": "4.0.23",`
`4`	`4`	`"description": "Node.js client library for SignalFx",`
`5`	`5`	`"homepage": "https://signalfx.com",`
`6`	`6`	`"repository": "https://github.com/signalfx/signalfx-nodejs",`