Extract inactive reconnect cleanup into dedicated helper

Co-authored-by: Eric Allam <eric@trigger.dev>

Author: cursoragent

packages/ai/src/chatTransport.ts

@@ -258,16 +258,7 @@ export class TriggerChatTransport<
     }
 
     if (!runState.isActive) {
-      try {
-        await this.runStore.delete(options.chatId);
-      } catch (error) {
-        await this.reportError({
-          phase: "reconnect",
-          chatId: runState.chatId,
-          runId: runState.runId,
-          error: normalizeError(error),
-        });
-      }
+      await this.cleanupInactiveReconnectState(runState);
       return null;
     }
 
@@ -423,6 +414,19 @@ export class TriggerChatTransport<
     }
   }
 
+  private async cleanupInactiveReconnectState(runState: TriggerChatRunState) {
+    try {
+      await this.runStore.delete(runState.chatId);
+    } catch (error) {
+      await this.reportError({
+        phase: "reconnect",
+        chatId: runState.chatId,
+        runId: runState.runId,
+        error: normalizeError(error),
+      });
+    }
+  }
+
   private async reportError(event: TriggerChatTransportError) {
     if (!this.onError) {
       return;