RanchiMall/SuperNodeStorage
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

forward data changes (tag/note) to liveRequests

Browse Source
This commit is contained in:
sairajzero 2022-03-07 04:23:08 +05:30
parent fbd515137b
commit a12bd9e2a2
2 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/client.js
View File

@ -152,6 +152,8 @@ function checkIfRequestSatisfy(request, data) {
return false; return false;
if (request.upperVectorClock && request.upperVectorClock < data.vectorClock) if (request.upperVectorClock && request.upperVectorClock < data.vectorClock)
return false; return false;
if (request.afterTime && request.afterTime > data.log_time)
return false;
if (request.application !== data.application) if (request.application !== data.application)
return false; return false;
if (request.comment && request.comment !== data.comment) if (request.comment && request.comment !== data.comment)

2
src/server.js
View File

@ -38,7 +38,7 @@ module.exports = function Server(port, client, intra) {
res.end(JSON.stringify(result[0])); res.end(JSON.stringify(result[0]));
if (result[1]) { if (result[1]) {
refresher.countdown; refresher.countdown;
if (result[1] === 'DATA') if (['DATA', 'TAG', 'NOTE'].includes(result[1]))
sendToLiveRequests(result[0]); sendToLiveRequests(result[0]);
intra.forwardToNextNode(result[1], result[0]); intra.forwardToNextNode(result[1], result[0]);
}; };