用 herdr 编排 codex：一个 Claude SDK 应用的构建复盘

 1@router.post("/api/sessions/{sid}/chat") 2async def chat(sid, text: Form, images: list[UploadFile] = []): 3    session = get_session(sid) 4    add_message(sid, "user", text) 5    history = get_history(sid)                 # [{role, text}] 6  7    async def sse(): 8        assistant, sidebar, engine_sid = [], [], None 9        # run_engine 把 codex / droid / claude-sdk 归一成同一套事件流10        async for ev in run_engine(session.engine, session.model,11                                   history, text, images, WORKDIR):12            yield f"data: {json.dumps(ev)}\n\n"          # 原样转发给浏览器13            if   ev["type"] == "text":     assistant.append(ev["delta"])14            elif ev["type"] in SIDEBAR:    sidebar.append(ev)   # thinking / tool_*15            elif ev["type"] == "done":     engine_sid = ev.get("engine_session_id")16        add_message(sid, "assistant", "".join(assistant),17                    events=sidebar, engine_session_id=engine_sid)18 19    return StreamingResponse(sse(), media_type="text/event-stream")

 1const res = await fetch(`/api/sessions/${sid}/chat`, { method: "POST", body: form }); 2const reader = res.body.getReader(); 3const dec = new TextDecoder(); let buf = ""; 4for (;;) { 5  const { value, done } = await reader.read(); if (done) break; 6  buf += dec.decode(value, { stream: true }); 7  let i; 8  while ((i = buf.indexOf("\n\n")) >= 0) {                 // 一个 SSE 帧 9    const ev = JSON.parse(buf.slice(0, i).replace(/^data: /, ""));10    buf = buf.slice(i + 2);11    if (ev.type === "text")            mainBubble.append(ev.delta);    // 中间列12    else if (ev.type === "thinking"13          || ev.type.startsWith("tool_")) sidebar.card(ev);           // 右列，默认折叠14  }15}

 1# 1 tab / 轮，1 pane / 并行 agent 2tab=$(herdr tab create --label round1 --cwd "$PROJ") 3herdr pane split $pane --direction down                  # -> N 个 pane 4herdr pane run  $pane 'codex exec --dangerously-bypass-approvals-and-sandbox \ 5                         - < promptA.md; echo ___DONE_A___' 6# block 到哨兵出现，再桌面通知 + 唤醒 orchestrator 7herdr wait output $pane --match ___DONE_A___ --timeout 2400000 8herdr notification show "round1: A done" --sound done

 1# SDK 的 message 流，逐 block 映射成统一事件 2options = ClaudeAgentOptions(model=model, cwd=workdir, 3                             permission_mode="bypassPermissions", 4                             resume=session_id)          # 有 id 就续，没有就新开 5async for message in query(prompt=prompt, options=options): 6    if is(message, "ResultMessage"):                     # turn 收尾 7        yield done_ev(seq, session_id, usage(message)); return 8    for block in getattr(message, "content", []): 9        if   is(block, "TextBlock") and is(message, "AssistantMessage"):10             yield text_ev(seq, block.text)              # -> 主对话11        elif is(block, "ThinkingBlock"):12             yield thinking_ev(seq, block.thinking)      # -> sidebar13        elif is(block, "ToolUseBlock"):14             yield tool_call_ev(seq, block.id, block.name, block.input)     # -> sidebar15        elif is(block, "ToolResultBlock"):16             yield tool_result_ev(seq, block.tool_use_id,17                                  not block.is_error, block.content)         # -> sidebar

 1async for line in proc.stdout:                 # codex exec --json 的 JSONL 2    item = json.loads(line).get("item") or {} 3    t = item.get("type") 4    if   t == "agent_message": yield text_ev(item["text"])       # -> 主对话 5    elif t == "reasoning":     yield thinking_ev(item["text"])   # -> sidebar 6    elif t in TOOLS:           yield tool_call_ev(...) / tool_result_ev(...) 7    elif t == "error":         yield thinking_ev("[codex] " + item["message"]) 8                               # ↑ 运维提示，不是 turn 失败：折进 sidebar， 9                               #   别当红色错误。真正失败走 turn.failed / 非零退出。