expired subscriptions and deleted topics with no subscribers are now removed from...

[websub-hub] / src / manager.js

diff --git a/src/manager.js b/src/manager.js
index 0f110682eb2b3f94ddd1fe0076dab22e620ce69a..cae9e74ce734b6fec771f4c9ceb3927c8e1b9028 100644 (file)
--- a/src/manager.js
+++ b/src/manager.js
@@ -626,6 +626,8 @@ class Manager {
           await this.db.topicDeleted(txCtx, topicId);
           res.end();
           this.logger.info(_scope, 'topic set deleted', { ctx, topicId });
+          // Attempt to remove from db if no active subscriptions.
+          await this.db.topicPendingDelete(txCtx, topicId);
           return;
         }