From 4554eeab912dcc395d70f93cce97c5fcd9dafe81 Mon Sep 17 00:00:00 2001 From: Danish Arora Date: Wed, 18 Sep 2024 11:34:20 +0530 Subject: [PATCH] chore: add logs for subscription maintenance --- packages/sdk/src/protocols/filter/constants.ts | 2 +- packages/sdk/src/protocols/filter/subscription_manager.ts | 3 +++ 2 files changed, 4 insertions(+), 1 deletion(-) diff --git a/packages/sdk/src/protocols/filter/constants.ts b/packages/sdk/src/protocols/filter/constants.ts index 3889e7638b..01cea6859f 100644 --- a/packages/sdk/src/protocols/filter/constants.ts +++ b/packages/sdk/src/protocols/filter/constants.ts @@ -1,4 +1,4 @@ -export const DEFAULT_KEEP_ALIVE = 30 * 1000; +export const DEFAULT_KEEP_ALIVE = 10_000; export const DEFAULT_SUBSCRIBE_OPTIONS = { keepAlive: DEFAULT_KEEP_ALIVE diff --git a/packages/sdk/src/protocols/filter/subscription_manager.ts b/packages/sdk/src/protocols/filter/subscription_manager.ts index be358d2c3d..7eb7559e3c 100644 --- a/packages/sdk/src/protocols/filter/subscription_manager.ts +++ b/packages/sdk/src/protocols/filter/subscription_manager.ts @@ -253,11 +253,13 @@ export class SubscriptionManager implements ISubscription { } private startSubscriptionsMaintenance(interval: number): void { + log.info("Starting subscriptions maintenance"); this.startKeepAlivePings(interval); this.startConnectionListener(); } private stopSubscriptionsMaintenance(): void { + log.info("Stopping subscriptions maintenance"); this.stopKeepAlivePings(); this.stopConnectionListener(); } @@ -301,6 +303,7 @@ export class SubscriptionManager implements ISubscription { } this.keepAliveTimer = setInterval(() => { + log.info("Sending keep-alive ping"); void this.ping() .then(() => log.info("Keep-alive ping successful")) .catch((error) => log.error("Error in keep-alive ping cycle:", error));