fix: pass abort signal to dial

libp2p · Feb 24, 2025 · 05cb100 · 05cb100
1 parent 2be16e0
commit 05cb100
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 3 deletions.
diff --git a/packages/libp2p-daemon-client/src/index.ts b/packages/libp2p-daemon-client/src/index.ts
@@ -45,11 +45,12 @@ class Client implements DaemonClient {
    * @async
    * @returns {MultiaddrConnection}
    */
-  async connectDaemon (): Promise<MultiaddrConnection> {
+  async connectDaemon (signal?: AbortSignal): Promise<MultiaddrConnection> {
     // @ts-expect-error because we use a passthrough upgrader,
     // this is actually a MultiaddrConnection and not a Connection
     return this.tcp.dial(this.multiaddr, {
-      upgrader: new PassThroughUpgrader()
+      upgrader: new PassThroughUpgrader(),
+      signal: signal ?? AbortSignal.timeout(10_000)
     })
   }
 

diff --git a/packages/libp2p-daemon-server/src/index.ts b/packages/libp2p-daemon-server/src/index.ts
@@ -148,7 +148,8 @@ export class Server implements Libp2pServer {
           // @ts-expect-error because we use a passthrough upgrader,
           // this is actually a MultiaddrConnection and not a Connection
           conn = await this.tcp.dial(addr, {
-            upgrader: new PassThroughUpgrader()
+            upgrader: new PassThroughUpgrader(),
+            signal: AbortSignal.timeout(10_000)
           })
 
           const message = StreamInfo.encode({