diff --git a/packages/streams/autodetect.js b/packages/streams/autodetect.js index 3c002417e..b18c59e50 100644 --- a/packages/streams/autodetect.js +++ b/packages/streams/autodetect.js @@ -113,6 +113,8 @@ Splitter.prototype._transform = function (msg, encoding, _done) { default: try { const parsed = JSON.parse(msg.data) + const timestamp = new Date(Number(msg.timestamp)) + parsed.updates && parsed.updates.forEach((update) => update.timestamp = timestamp) this.push(parsed) this.demuxEmitData(parsed) } catch (e) {