Function flushHistory

src/bridge/remoteBridgeCore.ts:651–683

(msgs: Message[])

  }

  async function flushHistory(msgs: Message[]): Promise<void> {
    // v2 always creates a fresh server session (unconditional createCodeSession
    // above) — no session reuse, no double-post risk. Unlike v1, we do NOT
    // filter by previouslyFlushedUUIDs: that set persists across REPL enable/
    // disable cycles (useRef), so it would wrongly suppress history on re-enable.
    const eligible = msgs.filter(isEligibleBridgeMessage)
    const capped =
      initialHistoryCap > 0 && eligible.length > initialHistoryCap
        ? eligible.slice(-initialHistoryCap)
        : eligible
    if (capped.length < eligible.length) {
      logForDebugging(
        `[remote-bridge] Capped initial flush: ${eligible.length} -> ${capped.length} (cap=${initialHistoryCap})`,
      )
    }
    const events: TransportMessage[] = toSDKMessages(capped).map(m => ({
      ...m,
      session_id: sessionId,
    })) as TransportMessage[]
    if (events.length === 0) return
    // Mid-turn init: if Remote Control is enabled while a query is running,
    // the last eligible message may be a real user prompt or tool_result.
    // Hidden slash-command scaffolding and pure reminder wrappers should not
    // resurrect a completed turn into "running". Check eligible (pre-cap),
    // not capped: the cap may truncate to a user message even when the actual
    // trailing message is assistant.
    const lastEligible = eligible.at(-1)
    if (lastEligible && shouldReportRunningForMessage(lastEligible)) {
      transport.reportState('running')
    }
    logForDebugging(`[remote-bridge] Flushing ${events.length} history events`)
    await transport.writeBatch(events as StdoutMessage[])
  }

  // ── 9. Teardown ───────────────────────────────────────────────────────────
  // On SIGINT/SIGTERM/⁠/exit, gracefulShutdown races runCleanupFunctions()