fix: fail after local relay

v0l · Jun 18, 2024 · 5ea7cd1 · 5ea7cd1
1 parent 338c4eb
commit 5ea7cd1
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 1 deletion.
diff --git a/packages/system/src/connection-pool.ts b/packages/system/src/connection-pool.ts
@@ -13,6 +13,7 @@ import { ConnectionSyncModule, DefaultSyncModule } from "./sync/connection";
 export interface ConnectionTypeEvents {
   change: () => void;
   connected: (wasReconnect: boolean) => void;
+  error: () => void;
   event: (sub: string, e: TaggedNostrEvent) => void;
   eose: (sub: string) => void;
   closed: (sub: string, reason: string) => void;

diff --git a/packages/system/src/connection.ts b/packages/system/src/connection.ts
@@ -150,7 +150,10 @@ export class Connection extends EventEmitter<ConnectionTypeEvents> implements Co
       this.Socket.onerror = e => this.#onError(e);
       this.Socket.onclose = e => this.#onClose(e);
       if (awaitOpen) {
-        await new Promise(resolve => this.once("connected", resolve));
+        await new Promise((resolve, reject) => {
+          this.once("connected", resolve);
+          this.once("error", reject);
+        });
       }
     } catch (e) {
       this.#connectStarted = false;
@@ -276,6 +279,7 @@ export class Connection extends EventEmitter<ConnectionTypeEvents> implements Co
   #onError(e: WebSocket.Event) {
     this.#log("Error: %O", e);
     this.emit("change");
+    this.emit("error");
   }
 
   /**