Fix streaming API double-JSON-encoding status IDs for deletes (#5069)

diff --git a/streaming/index.js b/streaming/index.js
index 3e80c8b3083dfcfbfd4d4c1dcd6b33673ed814e5..017073fa112fba7c2f8ac00d4020981b31a2e75b 100644 (file)
--- a/streaming/index.js
+++ b/streaming/index.js
@@ -264,7 +264,7 @@ const startWorker = (workerId) => {
       const transmit = () => {
         const now            = new Date().getTime();
         const delta          = now - queued_at;
-        const encodedPayload = typeof payload === 'number' ? payload : JSON.stringify(payload);
+        const encodedPayload = typeof payload === 'object' ? JSON.stringify(payload) : payload;
 
         log.silly(req.requestId, `Transmitting for ${req.accountId}: ${event} ${encodedPayload} Delay: ${delta}ms`);
         output(event, encodedPayload);