Function appendLog

yaml-flow-editor/vite.config.ts:225–272

(run: RunInfo, stream: 'stdout' | 'stderr', chunk: string)

  }

  function appendLog(run: RunInfo, stream: 'stdout' | 'stderr', chunk: string) {
    const prefix = stream === 'stderr' ? '[stderr] ' : ''
    const text = prefix + chunk
    run.log += text
    // cap memory usage (keep last ~200KB)
    if (run.log.length > 200_000) {
      run.log = run.log.slice(run.log.length - 200_000)
    }
    for (const sub of run.subscribers) {
      try {
        sseWrite(sub, 'log', { id: run.id, stream, chunk })
      } catch {
        // ignore broken pipes; cleanup happens on 'close'
      }
    }

    // UI input requests: detect sentinel lines emitted by the agent and broadcast as SSE.
    // Format: [ui-input-request]{...json...}
    try {
      const parts = text.split(/\r?\n/)
      for (const line of parts) {
        const m = line.match(/^\[ui-input-request\](\{.*\})\s*$/)
        if (!m) continue
        const payload = JSON.parse(m[1])
        for (const sub of run.subscribers) {
          try {
            sseWrite(sub, 'input_request', payload)
          } catch {
            // ignore
          }
        }
      }
    } catch {
      // ignore parse errors
    }

    // Discover dashboard port from run output (printed by scripts/run_agent.sh).
    // We proxy it through Vite so it works via port-forwarding / remote dev envs.
    if (!run.dashboardPort) {
      const m = text.match(DASHBOARD_PORT_RE)
      const port = m?.[1] ? Number(m[1]) : NaN
      if (Number.isFinite(port) && port > 0) {
        run.dashboardPort = port
        writeRunMeta(getProjectRoot(), run)
        broadcastStatus(run)
      }
    }
  }

  function broadcastStatus(run: RunInfo) {
    const payload = {