add disconnectTimeout option to rx-nostr config

packages/core/src/config/config.ts

@@ -13,6 +13,7 @@ export const makeRxNostrConfig = (config: RxNostrConfig) =>
       maxCount: 5,
       initialDelay: 1000,
     },
+    disconnectTimeout: 10_000,
     eoseTimeout: 30 * 1000,
     okTimeout: 30 * 1000,
     authTimeout: 30 * 1000,
@@ -48,6 +49,13 @@ export interface RxNostrConfig {
    * Auto reconnection strategy.
    */
   retry?: RetryConfig;
+
+  /**
+   * How long a relay connection should be held open when no longer used
+   * @default 5000
+   */
+  disconnectTimeout?: number,
+
   /**
    * Specify how long rx-nostr waits for EOSE messages in `use()` following backward strategy (milliseconds).
    *

packages/core/src/connection/connection.ts

@@ -43,6 +43,8 @@ export class NostrConnection {
   private defaultSubscriptionIds: Set<string> = new Set();
   private communicating = false;
   private strategy: ConnectionStrategy = "lazy";
+  private disconnectTimeout: number
+  private disconnectTimer?: ReturnType<typeof setTimeout>
   private isDefaultRelay = false;
   private disposed = false;
   private _url: string;
@@ -65,6 +67,8 @@ export class NostrConnection {
     this.pubProxy = pubProxy;
     this.subProxy = subProxy;
 
+    this.disconnectTimeout = config.disconnectTimeout
+
     // Idling cold sockets
     combineLatest([
       this.pubProxy.getLogicalConnectionSizeObservable(),
@@ -94,9 +98,18 @@ export class NostrConnection {
 
     switch (strategy) {
       case "lazy": {
-        if (!this.communicating) {
-          this.relay.disconnect(WebSocketCloseCode.RX_NOSTR_IDLE);
+        // clear existing timer
+        if(this.disconnectTimeout) {
+          clearTimeout(this.disconnectTimer)
+          this.disconnectTimer=undefined
         }
+
+        // create a new timer
+        this.disconnectTimer = setTimeout(() => {
+          if (!this.communicating) {
+            this.relay.disconnect(WebSocketCloseCode.RX_NOSTR_IDLE);
+          }
+        }, this.disconnectTimeout);
         break;
       }
       case "lazy-keep": {
@@ -254,6 +267,9 @@ export class NostrConnection {
 
     this.disposed = true;
 
+    if(this.disconnectTimer) clearTimeout(this.disconnectTimer)
+    this.disconnectTimer=undefined
+
     this.relay.dispose();
     this.pubProxy.dispose();
     this.subProxy.dispose();