Revert "fix: trigger reconnection on bridge read NotLeaderError"

This reverts commit 8b02d15.

Author: w1am

packages/db-client/src/Client/index.ts

@@ -692,36 +692,4 @@ export class Client {
   public get rustClient(): bridge.RustClient {
     return this.#rustClient;
   }
-
-  public handleBridgeError = async (error: Error): Promise<void> => {
-    const [reconnect, nextEndpoint] = this.shouldReconnect(error);
-
-    if (!reconnect) return;
-
-    debug.connection("Got bridge reconnection error", error.message);
-
-    const currentChannel = await this.#channel;
-    if (!currentChannel) {
-      debug.connection("No channel to reconnect");
-      return;
-    }
-
-    debug.connection(
-      `Reconnection required${nextEndpoint ? ` to: ${nextEndpoint}` : ""}`
-    );
-
-    const [_protocol, address, port] = currentChannel.getTarget().split(":");
-
-    currentChannel.close();
-    this.#grpcClients.clear();
-    this.#channel = undefined;
-    this.#serverFeatures = undefined;
-    this.#nextChannelSettings = {
-      failedEndpoint: {
-        address,
-        port: Number.parseInt(port),
-      },
-      nextEndpoint,
-    };
-  };
 }

packages/db-client/src/streams/readAll.ts

@@ -78,12 +78,9 @@ Client.prototype.readAll = function (
   try {
     stream = this.rustClient.readAll(options);
   } catch (error) {
-    const bridgeError = convertBridgeError(error);
-    this.handleBridgeError(bridgeError);
-    throw bridgeError;
+    throw convertBridgeError(error);
   }
 
-  const handleBridgeError = this.handleBridgeError;
   const convert = async function* (
     stream: AsyncIterable<bridge.ResolvedEvent[]>
   ) {
@@ -94,9 +91,7 @@ Client.prototype.readAll = function (
         }
       }
     } catch (error) {
-      const bridgeError = convertBridgeError(error);
-      await handleBridgeError(bridgeError);
-      throw bridgeError;
+      throw convertBridgeError(error);
     }
   };
 

packages/db-client/src/streams/readStream.ts

@@ -108,12 +108,9 @@ Client.prototype.readStream = function <
   try {
     stream = this.rustClient.readStream(streamName, options);
   } catch (error) {
-    const bridgeError = convertBridgeError(error, streamName);
-    this.handleBridgeError(bridgeError);
-    throw bridgeError;
+    throw convertBridgeError(error, streamName);
   }
 
-  const handleBridgeError = this.handleBridgeError;
   const convert = async function* (
     stream: AsyncIterable<bridge.ResolvedEvent[]>
   ) {
@@ -124,9 +121,7 @@ Client.prototype.readStream = function <
         }
       }
     } catch (error) {
-      const bridgeError = convertBridgeError(error, streamName);
-      await handleBridgeError(bridgeError);
-      throw bridgeError;
+      throw convertBridgeError(error, streamName);
     }
   };