diff --git a/src/controllers/RelayController.ts b/src/controllers/RelayController.ts index 4ab711c..9bb969c 100644 --- a/src/controllers/RelayController.ts +++ b/src/controllers/RelayController.ts @@ -121,7 +121,7 @@ export class RelayController { return new Promise((resolve) => { if (!relay.connected) { console.log(`${relay.url} : Not connected!`, 'Skipping subscription') - return + return resolve() } // Subscribe to the relay with the specified filter @@ -140,6 +140,14 @@ export class RelayController { resolve() // Resolve the promise when EOSE is received } }) + + // add a 30 sec of timeout to subscription + setTimeout(() => { + if (!sub.closed) { + sub.close() + resolve() + } + }, 30 * 1000) }) })