refactor(acp): 收敛 ACP bridge 的 SDK 消息类型边界

这个 PR 不改变 ACP 的运行时协议行为，只收敛 bridge.ts 内部的 SDKMessage 类型边界。
当前 nextSdkMessageOrAbort() 把 IteratorResult<SDKMessage, void> 暴露给主循环，导致 nextResult.value 变成 SDKMessage | void，后续字段访问依赖大量 cast。
本 PR：
• 将 done/value 判断封装在 nextSdkMessageOrAbort() 内部
• 主循环只接收 SDKMessage | undefined
• 在 bridge.ts 内部增加局部 BridgeSDKMessage union
• 不修改全局 SDKMessage，避免影响其他模块
目标是提升 ACP bridge 的类型安全和后续可维护性，不改变现有 ACP 行为。

Author: James-FE

src/services/acp/__tests__/bridge.test.ts

@@ -4,6 +4,7 @@ import {
   toolUpdateFromToolResult,
   toolUpdateFromEditToolResponse,
   forwardSessionUpdates,
+  nextSdkMessageOrAbort,
 } from '../bridge.js'
 import { promptToQueryInput } from '../promptConversion.js'
 import { markdownEscape, toDisplayPath } from '../utils.js'
@@ -30,6 +31,10 @@ async function* makeStream(
   for (const m of msgs) yield m
 }
 
+async function* makeWaitingStream(): AsyncGenerator<SDKMessage, void, unknown> {
+  await new Promise<never>(() => {})
+}
+
 // ── toolInfoFromToolUse ────────────────────────────────────────────
 
 describe('toolInfoFromToolUse', () => {
@@ -692,6 +697,47 @@ describe('toDisplayPath', () => {
 
 // ── forwardSessionUpdates ─────────────────────────────────────────
 
+describe('nextSdkMessageOrAbort', () => {
+  test('returns undefined when aborted while waiting for next message', async () => {
+    const ac = new AbortController()
+    const pending = nextSdkMessageOrAbort(makeWaitingStream(), ac.signal)
+    ac.abort()
+
+    const result = await Promise.race([
+      pending,
+      new Promise<'timeout'>(resolve => setTimeout(resolve, 100, 'timeout')),
+    ])
+
+    expect(result).toBeUndefined()
+  })
+
+  test('returns undefined when stream is done', async () => {
+    const result = await nextSdkMessageOrAbort(
+      makeStream([]),
+      new AbortController().signal,
+    )
+
+    expect(result).toBeUndefined()
+  })
+
+  test('returns a valid SDKMessage', async () => {
+    const msg = {
+      type: 'assistant',
+      message: {
+        role: 'assistant',
+        content: [{ type: 'text', text: 'hello' }],
+      },
+    } as unknown as SDKMessage
+
+    const result = await nextSdkMessageOrAbort(
+      makeStream([msg]),
+      new AbortController().signal,
+    )
+
+    expect(result).toBe(msg)
+  })
+})
+
 describe('forwardSessionUpdates', () => {
   test('returns end_turn when stream is empty', async () => {
     const conn = makeConn()
@@ -1077,6 +1123,28 @@ describe('forwardSessionUpdates', () => {
     ).toBe(0)
   })
 
+  test('ignores unknown message types without crashing', async () => {
+    const conn = makeConn()
+    const debug = console.debug
+    const debugMock = mock(() => {})
+    console.debug = debugMock as typeof console.debug
+
+    try {
+      const result = await forwardSessionUpdates(
+        's1',
+        makeStream([{ type: 'future_message' } as unknown as SDKMessage]),
+        conn,
+        new AbortController().signal,
+        {},
+      )
+
+      expect(result.stopReason).toBe('end_turn')
+      expect(debugMock).toHaveBeenCalled()
+    } finally {
+      console.debug = debug
+    }
+  })
+
   test('re-throws unexpected errors from stream', async () => {
     const conn = makeConn()
     async function* errorStream(): AsyncGenerator<