fix: improve error mapping for leader failover reconnection

- Map gRPC INTERNAL and DATA_LOSS status codes to UnavailableError so
  the client retries on these transient failures during leader failover
- Add UnavailableError, DeadlineExceededError, and UnknownError handling
  to bridge error conversion
- Use string literals for error name matching instead of class .name
  references for reliability
- Remove stale commented-out code in convertBridgeError
- Default unrecognized bridge errors to UnknownError instead of passing
  through the raw error

Author: w1am

packages/db-client/src/utils/CommandError.ts

@@ -640,6 +640,8 @@ export const convertToCommandError = (error: Error): CommandError | Error => {
     case StatusCode.DEADLINE_EXCEEDED:
       return new DeadlineExceededError(error);
     case StatusCode.UNAVAILABLE:
+    case StatusCode.INTERNAL:
+    case StatusCode.DATA_LOSS:
       return new UnavailableError(error);
     case StatusCode.UNAUTHENTICATED:
       return new AccessDeniedError(error);

packages/db-client/src/utils/convertBridgeError.ts

@@ -3,43 +3,32 @@ import {
   StreamNotFoundError,
   StreamDeletedError,
   AccessDeniedError,
+  UnavailableError,
+  DeadlineExceededError,
+  UnknownError,
 } from "./CommandError";
 import { ServiceError } from "@grpc/grpc-js";
 
-// export const convertBridgeError = (
-//   error: ServiceError,
-//   streamName?: string
-// ) => {
-//   const stream = streamName ?? "unknown stream";
-//
-//   switch (error.name) {
-//     case StreamNotFoundError.name:
-//       throw new StreamNotFoundError(error, stream);
-//     case StreamDeletedError.name:
-//       throw StreamDeletedError.fromStreamName(stream);
-//     case NotLeaderError.name:
-//       throw new NotLeaderError(error);
-//     case AccessDeniedError.name:
-//       throw new AccessDeniedError(error);
-//     default:
-//       throw error;
-//   }
-// };
-
 export const convertBridgeError = (error: Error, streamName?: string) => {
   const stream = streamName ?? "unknown stream";
   const serviceError = error as ServiceError;
 
   switch (error.name) {
-    case StreamNotFoundError.name:
+    case "StreamNotFoundError":
       return new StreamNotFoundError(serviceError, stream);
-    case StreamDeletedError.name:
+    case "StreamDeletedError":
       return StreamDeletedError.fromStreamName(stream);
-    case NotLeaderError.name:
+    case "NotLeaderError":
       return new NotLeaderError(serviceError);
-    case AccessDeniedError.name:
+    case "AccessDeniedError":
       return new AccessDeniedError(serviceError);
+    case "UnavailableError":
+      return new UnavailableError(serviceError);
+    case "DeadlineExceededError":
+      return new DeadlineExceededError(serviceError);
+    case "UnknownError":
+      return new UnknownError(serviceError);
     default:
-      return error;
+      return new UnknownError(serviceError);
   }
 };