From 4b792963f5616ae4d269bccba7191913e157b045 Mon Sep 17 00:00:00 2001
From: backryun <bakryun0718@proton.me>
Date: Thu, 6 Aug 2026 10:31:30 +0900
Subject: [PATCH] fix(types): align web executor event contracts (#9138)
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

Validated in local merge-train (devbox-vm-06-dev002) @ combined-tip (FAST gates: typecheck/complexity/cognitive/changelog/vitest — only pre-existing audit.test.ts flake). Evidence: /home/diegosouzapw/dev/proxys/OmniRoute/.claude/worktrees/merge-train-20260805-222248-suite.log
---
 open-sse/executors/claude-web/stream.ts | 5 +++--
 open-sse/executors/inner-ai.ts          | 5 ++---
 2 files changed, 5 insertions(+), 5 deletions(-)

diff --git a/open-sse/executors/claude-web/stream.ts b/open-sse/executors/claude-web/stream.ts
index 82281bb02b..264f8218e8 100644
--- a/open-sse/executors/claude-web/stream.ts
+++ b/open-sse/executors/claude-web/stream.ts
@@ -148,7 +148,8 @@ async function* decodeSseData(
 }
 
 function safeMetadataValue(value: unknown): string | number | boolean | null | undefined {
-  if (value === null || typeof value === "boolean") return value;
+  if (value === null) return null;
+  if (typeof value === "boolean") return value;
   if (typeof value === "number" && Number.isFinite(value)) return value;
   if (typeof value === "string" && value.length <= 128 && /^[A-Za-z0-9._:+/@-]+$/.test(value)) {
     return value;
@@ -715,7 +716,7 @@ async function pullStreamingChunk(
     while (!state.terminal) {
       const next = await state.iterator.next();
       if (state.control.cancelled) return;
-      if (next.done) {
+      if (next.done === true) {
         throw new ClaudeWebProtocolError("Claude Web stream ended without a terminal event");
       }
       await queueSemanticEvent(state, next.value, options);
diff --git a/open-sse/executors/inner-ai.ts b/open-sse/executors/inner-ai.ts
index 27a535daef..261a75468e 100644
--- a/open-sse/executors/inner-ai.ts
+++ b/open-sse/executors/inner-ai.ts
@@ -23,6 +23,7 @@ interface InnerAiModel {
   unavailable_api?: boolean;
   pro_only?: boolean;
   ultra_only?: boolean;
+  ai_model_categories?: Array<Record<string, unknown>>;
 }
 
 interface CredentialCache {
@@ -283,9 +284,7 @@ async function resolveModels(
     if (m.enable === false || m.unavailable_api) return false;
     if (m.ultra_only && !isUltra) return false;
     if (m.pro_only && !isPro) return false;
-    const cats = Array.isArray((m as Record<string, unknown>).ai_model_categories)
-      ? ((m as Record<string, unknown>).ai_model_categories as Array<Record<string, unknown>>)
-      : null;
+    const cats = Array.isArray(m.ai_model_categories) ? m.ai_model_categories : null;
     if (cats && cats.length > 0) {
       return cats.some((c) => String(c.unique_identifier ?? c.name ?? "").toLowerCase() === "text");
     }