indexer: fix reconnect on internal server errors

change/@apibara-indexer-6840c283-48ae-4a3f-a3e7-706e002bd6a1.json

@@ -0,0 +1,7 @@
+{
+  "type": "prerelease",
+  "comment": "indexer: fix reconnect on internal server errors",
+  "packageName": "@apibara/indexer",
+  "email": "jadejajaipal5@gmail.com",
+  "dependentChangeType": "patch"
+}

change/@apibara-protocol-aa5f0bd5-4da3-47e9-997b-32940c921233.json

@@ -0,0 +1,7 @@
+{
+  "type": "prerelease",
+  "comment": "indexer: fix reconnect on internal server errors",
+  "packageName": "@apibara/protocol",
+  "email": "jadejajaipal5@gmail.com",
+  "dependentChangeType": "patch"
+}

packages/indexer/src/indexer.ts

@@ -5,6 +5,7 @@ import {
   type DataFinality,
   type Finalize,
   type Invalidate,
+  ServerError,
   Status,
   type StreamConfig,
   type StreamDataOptions,
@@ -179,13 +180,18 @@ export async function runWithReconnect<TFilter, TBlock>(
 
       retryCount++;
 
-      if (error instanceof ClientError) {
+      if (error instanceof ClientError || error instanceof ServerError) {
+        const isServerError = error instanceof ServerError;
+
         if (error.code === Status.INTERNAL) {
           if (retryCount < maxRetries) {
             consola.error(
-              "Internal server error, reconnecting...",
-              error.message,
+              `Internal ${isServerError ? "server" : "client"} error: ${
+                error.message
+              }`,
             );
+            consola.start("Reconnecting...");
+            console.log();
 
             // Add jitter to the retry delay to avoid all clients retrying at the same time.
             const delay = Math.random() * (retryDelay * 0.2) + retryDelay;

packages/protocol/src/client.ts

@@ -16,7 +16,7 @@ import type { StreamConfig } from "./config";
 import { StatusRequest, StatusResponse } from "./status";
 import { type StreamDataRequest, StreamDataResponse } from "./stream";
 
-export { ClientError, Status, Metadata } from "nice-grpc";
+export { ClientError, ServerError, Status, Metadata } from "nice-grpc";
 
 const DEFAULT_TIMEOUT_MS = 45_000;