feat(rosenet-node): add signal to dial and newStream calls

.changeset/cuddly-hotels-scream.md

@@ -0,0 +1,5 @@
+---
+'@rosen-bridge/rosenet-node': minor
+---
+
+Abort connection establishment or stream creation after a predefined duration

packages/rosenet-node/lib/constants.ts

@@ -1,3 +1,5 @@
 export const RELAYS_COUNT_TO_CONNECT = 3;
 export const ROSENET_DIRECT_PROTOCOL_V1 = '/rosenet/direct/1';
 export const DEFAULT_NODE_PORT = 55123;
+export const STREAM_CREATION_TIMEOUT = 500;
+export const CONNECTION_CREATION_TIMEOUT = 1000;

packages/rosenet-node/lib/stream/stream-service.ts

@@ -6,7 +6,11 @@ import { Libp2p } from 'libp2p';
 import RoseNetNodeContext from '../context/RoseNetNodeContext';
 import createPushable, { Pushable } from './createPushable';
 
-import { ROSENET_DIRECT_PROTOCOL_V1 } from '../constants';
+import {
+  CONNECTION_CREATION_TIMEOUT,
+  ROSENET_DIRECT_PROTOCOL_V1,
+  STREAM_CREATION_TIMEOUT,
+} from '../constants';
 
 const cache = new Map<
   string,
@@ -53,7 +57,11 @@ async function getStreamAndPushable(to: string, node: Libp2p) {
   const possibleOpenConnectionToPeer = allConnectionsToPeer.find(
     (connection) => connection.status === 'open',
   );
-  const connection = possibleOpenConnectionToPeer ?? (await node.dial(peerId));
+  const connection =
+    possibleOpenConnectionToPeer ??
+    (await node.dial(peerId, {
+      signal: AbortSignal.timeout(CONNECTION_CREATION_TIMEOUT),
+    }));
 
   RoseNetNodeContext.logger.debug(
     possibleOpenConnectionToPeer
@@ -78,6 +86,7 @@ async function getStreamAndPushable(to: string, node: Libp2p) {
     possibleWritableStream ??
     (await connection.newStream(ROSENET_DIRECT_PROTOCOL_V1, {
       runOnTransientConnection: true,
+      signal: AbortSignal.timeout(STREAM_CREATION_TIMEOUT),
     }));
 
   RoseNetNodeContext.logger.debug(