Function drainFlushGate

src/bridge/remoteBridgeCore.ts:634–649

()

  // ── 8. History flush + drain helpers ────────────────────────────────────
  function drainFlushGate(): void {
    const msgs = flushGate.end()
    if (msgs.length === 0) return
    for (const msg of msgs) recentPostedUUIDs.add(msg.uuid)
    const events: TransportMessage[] = toSDKMessages(msgs).map(m => ({
      ...m,
      session_id: sessionId,
    })) as TransportMessage[]
    if (shouldReportRunningForMessages(msgs)) {
      transport.reportState('running')
    }
    logForDebugging(
      `[remote-bridge] Drained ${msgs.length} queued message(s) after flush`,
    )
    void transport.writeBatch(events as StdoutMessage[])
  }

  async function flushHistory(msgs: Message[]): Promise<void> {
    // v2 always creates a fresh server session (unconditional createCodeSession