Function writeSdkMessages

src/bridge/replBridge.ts:1814–1838

(messages)

      void transport.writeBatch(events as StdoutMessage[])
    },
    writeSdkMessages(messages) {
      // Daemon path: query() already yields SDKMessage, skip conversion.
      // Still run echo dedup (server bounces writes back on the WS).
      // No initialMessageUUIDs filter — daemon has no initial messages.
      // No flushGate — daemon never starts it (no initial flush).
      const filtered = messages.filter(
        m => !m.uuid || !recentPostedUUIDs.has(m.uuid as string),
      )
      if (filtered.length === 0) return
      if (!transport) {
        logForDebugging(
          `[bridge:repl] Transport not configured, dropping ${filtered.length} SDK message(s) for session=${currentSessionId}`,
          { level: 'warn' },
        )
        return
      }
      for (const msg of filtered) {
        if (msg.uuid) recentPostedUUIDs.add(msg.uuid as string)
      }
      const events: TransportMessage[] = filtered.map(m => ({
        ...m,
        session_id: currentSessionId,
      })) as TransportMessage[]
      void transport.writeBatch(events as StdoutMessage[])
    },
    sendControlRequest(request: SDKControlRequest) {
      if (!transport) {
        logForDebugging(