projects
/
websub-hub
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
db migration 1.0.2, now stores and indexes date of content delivered to subscriber...
[websub-hub]
/
src
/
communication.js
diff --git
a/src/communication.js
b/src/communication.js
index 03cc670dd7154ccc64a50b87f4d7bb1d5eddafb3..dc4d464c70111b4ea2a8971575940c099d14b379 100644
(file)
--- a/
src/communication.js
+++ b/
src/communication.js
@@
-565,7
+565,7
@@
class Communication {
await this.db.transaction(dbCtx, async (txCtx) => {
await this.db.verificationInsert(txCtx, verification);
await this.db.transaction(dbCtx, async (txCtx) => {
await this.db.verificationInsert(txCtx, verification);
- await this.db.subscriptionDeliveryComplete(txCtx, subscription.callback, subscription.topicId);
+ await this.db.subscriptionDeliveryComplete(txCtx, subscription.callback, subscription.topicId
, topic.contentUpdated
);
});
this.logger.info(_scope, 'update unsubscription for deleted topic', logInfoData);
return;
});
this.logger.info(_scope, 'update unsubscription for deleted topic', logInfoData);
return;
@@
-617,7
+617,7
@@
class Communication {
return;
}
return;
}
- await this.db.subscriptionDeliveryComplete(dbCtx, subscription.callback, subscription.topicId);
+ await this.db.subscriptionDeliveryComplete(dbCtx, subscription.callback, subscription.topicId
, topic.contentUpdated
);
this.logger.info(_scope, 'update success', logInfoData);
}
this.logger.info(_scope, 'update success', logInfoData);
}