From a12bd9e2a2785f03dde79afc14713e87f0e1aa0f Mon Sep 17 00:00:00 2001 From: sairajzero Date: Mon, 7 Mar 2022 04:23:08 +0530 Subject: [PATCH] forward data changes (tag/note) to liveRequests --- src/client.js | 2 ++ src/server.js | 2 +- 2 files changed, 3 insertions(+), 1 deletion(-) diff --git a/src/client.js b/src/client.js index 735ca41..85190f1 100644 --- a/src/client.js +++ b/src/client.js @@ -152,6 +152,8 @@ function checkIfRequestSatisfy(request, data) { return false; if (request.upperVectorClock && request.upperVectorClock < data.vectorClock) return false; + if (request.afterTime && request.afterTime > data.log_time) + return false; if (request.application !== data.application) return false; if (request.comment && request.comment !== data.comment) diff --git a/src/server.js b/src/server.js index 70c0b16..feddba3 100644 --- a/src/server.js +++ b/src/server.js @@ -38,7 +38,7 @@ module.exports = function Server(port, client, intra) { res.end(JSON.stringify(result[0])); if (result[1]) { refresher.countdown; - if (result[1] === 'DATA') + if (['DATA', 'TAG', 'NOTE'].includes(result[1])) sendToLiveRequests(result[0]); intra.forwardToNextNode(result[1], result[0]); };