From 8934fba527caaf16bc233319d12e114dc52276bd Mon Sep 17 00:00:00 2001
From: Gancho Radkov <ganchoradkov93@gmail.com>
Date: Fri, 3 Feb 2023 13:28:17 +0200
Subject: [PATCH] fix: avoids restarting transport if explicitly closed

---
 packages/core/src/controllers/relayer.ts | 14 +++++++++++---
 1 file changed, 11 insertions(+), 3 deletions(-)

diff --git a/packages/core/src/controllers/relayer.ts b/packages/core/src/controllers/relayer.ts
index 86f790195..453cb2d5f 100644
--- a/packages/core/src/controllers/relayer.ts
+++ b/packages/core/src/controllers/relayer.ts
@@ -59,7 +59,7 @@ export class Relayer extends IRelayer {
   public transportExplicitlyClosed = false;
 
   private initialized = false;
-
+  private reconnecting = false;
   private relayUrl: string;
   private projectId: string | undefined;
   constructor(opts: RelayerOptions) {
@@ -155,8 +155,10 @@ export class Relayer extends IRelayer {
   }
 
   public async transportOpen(relayUrl?: string) {
+    if (this.reconnecting) return;
     this.relayUrl = relayUrl || this.relayUrl;
     this.transportExplicitlyClosed = false;
+    this.reconnecting = true;
     try {
       await Promise.all([
         new Promise<void>((resolve) => {
@@ -181,14 +183,20 @@ export class Relayer extends IRelayer {
     } catch (e: unknown | Error) {
       const error = e as Error;
       if (!/socket hang up/i.test(error.message)) {
-        throw new Error(error.message);
+        throw e;
       }
-      this.logger.error(error);
+      this.logger.error(e);
       this.events.emit(RELAYER_EVENTS.transport_closed);
+    } finally {
+      this.reconnecting = false;
     }
   }
 
   public async restartTransport(relayUrl?: string) {
+    if (this.transportExplicitlyClosed) {
+      return;
+    }
+
     await this.transportClose();
     await new Promise<void>((resolve) => setTimeout(resolve, RELAYER_RECONNECT_TIMEOUT));
     await this.transportOpen(relayUrl);