|
{"1"}
|
{"+"}
|
{"// langgraph 的 adapter:无侵入对接 ../src/backend/server.py —— 自定义 JSON 帧 over SSE"}
|
|
{"2"}
|
{"+"}
|
{"// (server.py 不透传 LangGraph 原生 stream 事件,自己翻译成一套小协议,见其头注释)。"}
|
|
{"3"}
|
{"+"}
|
{"//"}
|
|
{"4"}
|
{"+"}
|
{"// 事件来源:`events: otelEvents({ dialects: [otel.langsmith] })`——LangSmith OTel 导出的"}
|
|
{"5"}
|
{"+"}
|
{"// span 派生 action.called / action.result / usage。`tool-output` 帧不用翻译;`tool-input`"}
|
|
{"6"}
|
{"+"}
|
{"// 帧仍然补一条 action.called(见下方 deny 分支的说明,denied 的调用从来不会真的执行,没有"}
|
|
{"7"}
|
{"+"}
|
{"// span 可派生),和 span 派生的重复也没关系(otelEvents 按 callId 去重,见"}
|
|
{"8"}
|
{"+"}
|
{"// src/o11y/otlp/dialects.ts 的 mergeDerivedEvents)。"}
|
|
{"9"}
|
{"+"}
|
{"//"}
|
|
{"10"}
|
{"+"}
|
{"// 消息文本例外——这里没有照抄\"span 全包\"的理想状态,是实测出来的:langsmith 方言的 \"llm\""}
|
|
{"11"}
|
{"+"}
|
{"// 分支只认得 gen_ai.completion 是纯字符串 / {content} / 消息数组三种形状,LangChain 的"}
|
|
{"12"}
|
{"+"}
|
{"// ChatOpenAI 包装器实际吐的是 `{generations:[[{text, message, ...}]]}`(生成候选数组套一层),"}
|
|
{"13"}
|
{"+"}
|
{"// 三种形状都不命中,text 解析成 undefined,message 事件直接丢空——工具调用和 usage 派生完全"}
|
|
{"14"}
|
{"+"}
|
{"// 正常(它们走的是 \"tool\" 分支,shape 对得上),只有 assistant 文本这条链路对不上 LangChain"}
|
|
{"15"}
|
{"+"}
|
{"// 这个生态的实际输出。核心的 langsmith dialect 不归这次 Tier 1 工单改,所以在 adapter 这层"}
|
|
{"16"}
|
{"+"}
|
{"// 补一条:累积 `text-delta` 帧(应用自己逐 token 吐的,协议里本来就有)拼成完整回复,在这一轮"}
|
|
{"17"}
|
{"+"}
|
{"// 结束时补一条 message 事件——按文档\"send 的 events 与 span 派生结果按时间戳合并\"设计,这不是"}
|
|
{"18"}
|
{"+"}
|
{"// hack,是两条事件来源分工:span 管工具 + usage,adapter 补 span 这个生态解析不出来的消息文本。"}
|
|
{"19"}
|
{"+"}
|
{"//"}
|
|
{"20"}
|
{"+"}
|
{"// HITL 是唯一 span 管不到的部分:`tool-approval-request` → input.requested + waiting;"}
|
|
{"21"}
|
{"+"}
|
{"// `tool-output-denied` → action.result(status:\"rejected\",span 里没有\"人拒绝\"这个语义,"}
|
|
{"22"}
|
{"+"}
|
{"// 这条要 adapter 自己补)。approve 端点字段是 toolCallId(不是 pi-sdk/claude-sdk 那个"}
|
|
{"23"}
|
{"+"}
|
{"// toolUseId)。"}
|
|
{"24"}
|
{"+"}
|
{"import"}
{" { defineAgent, otelEvents, otel, serverSession, sseJsonFrames } "}
{"from"}
{" "}
{"\"niceeval/adapter\""}
{";"}
|
|
{"25"}
|
{"+"}
|
{"import"}
{" "}
{"type"}
{" { AgentContext, SseFrameCursor } "}
{"from"}
{" "}
{"\"niceeval/adapter\""}
{";"}
|
|
{"26"}
|
{"+"}
|
{"import"}
{" "}
{"type"}
{" { JsonValue, StreamEvent, Turn, TurnInput } "}
{"from"}
{" "}
{"\"niceeval\""}
{";"}
|
|
{"27"}
|
{"+"}
|
{" "}
|
|
{"28"}
|
{"+"}
|
{"// 被测应用由你自己按它的方式启动(python server.py / 部署在哪都行),eval 不代管进程、"}
|
|
{"29"}
|
{"+"}
|
{"// 不另开端口。LangSmith OTel 导出的环境变量在启动应用时给,见 README「跑起来」。"}
|
|
{"30"}
|
{"+"}
|
{"const"}
{" "}
{"BASE_URL"}
{" "}
{"="}
{" process.env."}
{"LANGGRAPH_URL"}
{" "}
{"??"}
{" "}
{"\"http://127.0.0.1:5488\""}
{";"}
|
|
{"31"}
|
{"+"}
|
{" "}
|
|
{"32"}
|
{"+"}
|
{"async"}
{" "}
{"function"}
{" "}
{"appFetch"}
{"("}
|
|
{"33"}
|
{"+"}
|
{" "}
{"path"}
{":"}
{" "}
{"string"}
{","}
|
|
{"34"}
|
{"+"}
|
{" "}
{"body"}
{":"}
{" "}
{"unknown"}
{","}
|
|
{"35"}
|
{"+"}
|
{" "}
{"signal"}
{":"}
{" "}
{"AbortSignal"}
{","}
|
|
{"36"}
|
{"+"}
|
{" "}
{"headers"}
{"?:"}
{" "}
{"Readonly"}
{"<"}
{"Record"}
{"<"}
{"string"}
{", "}
{"string"}
{">>,"}
|
|
{"37"}
|
{"+"}
|
{")"}
{":"}
{" "}
{"Promise"}
{"<"}
{"Response"}
{"> {"}
|
|
{"38"}
|
{"+"}
|
{" "}
{"try"}
{" {"}
|
|
{"39"}
|
{"+"}
|
{" "}
{"return"}
{" "}
{"await"}
{" "}
{"fetch"}
{"("}
{"`${"}
{"BASE_URL"}
{"}${"}
{"path"}
{"}`"}
{", {"}
|
|
{"40"}
|
{"+"}
|
{" method: "}
{"\"POST\""}
{","}
|
|
{"41"}
|
{"+"}
|
{" headers: { "}
{"\"content-type\""}
{": "}
{"\"application/json\""}
{", "}
{"..."}
{"headers },"}
|
|
{"42"}
|
{"+"}
|
{" body: "}
{"JSON"}
{"."}
{"stringify"}
{"(body),"}
|
|
{"43"}
|
{"+"}
|
{" signal,"}
|
|
{"44"}
|
{"+"}
|
{" });"}
|
|
{"45"}
|
{"+"}
|
{" } "}
{"catch"}
{" (err) {"}
|
|
{"46"}
|
{"+"}
|
{" "}
{"if"}
{" (signal.aborted) "}
{"throw"}
{" err;"}
|
|
{"47"}
|
{"+"}
|
{" "}
{"throw"}
{" "}
{"new"}
{" "}
{"Error"}
{"("}
|
|
{"48"}
|
{"+"}
|
{" "}
{"`连不上 ${"}
{"BASE_URL"}
{"}${"}
{"path"}
{"}。被测应用在跑吗?先起它(见 README「跑起来」),或设 LANGGRAPH_URL 指向已部署实例。`"}
{","}
|
|
{"49"}
|
{"+"}
|
{" );"}
|
|
{"50"}
|
{"+"}
|
{" }"}
|
|
{"51"}
|
{"+"}
|
{"}"}
|
|
{"52"}
|
{"+"}
|
{" "}
|
|
{"53"}
|
{"+"}
|
{"type"}
{" "}
{"LanggraphFrame"}
{" "}
{"="}
|
|
{"54"}
|
{"+"}
|
{" "}
{"|"}
{" { "}
{"type"}
{":"}
{" "}
{"\"session\""}
{"; "}
{"sessionId"}
{":"}
{" "}
{"string"}
{" }"}
|
|
{"55"}
|
{"+"}
|
{" "}
{"|"}
{" { "}
{"type"}
{":"}
{" "}
{"\"text-delta\""}
{"; "}
{"delta"}
{":"}
{" "}
{"string"}
{" }"}
|
|
{"56"}
|
{"+"}
|
{" "}
{"|"}
{" { "}
{"type"}
{":"}
{" "}
{"\"tool-input\""}
{"; "}
{"toolCallId"}
{":"}
{" "}
{"string"}
{"; "}
{"name"}
{":"}
{" "}
{"string"}
{"; "}
{"input"}
{":"}
{" "}
{"unknown"}
{" }"}
|
|
{"57"}
|
{"+"}
|
{" "}
{"|"}
{" { "}
{"type"}
{":"}
{" "}
{"\"tool-output\""}
{"; "}
{"toolCallId"}
{":"}
{" "}
{"string"}
{"; "}
{"output"}
{":"}
{" "}
{"unknown"}
{" }"}
|
|
{"58"}
|
{"+"}
|
{" "}
{"|"}
{" { "}
{"type"}
{":"}
{" "}
{"\"tool-approval-request\""}
{"; "}
{"toolCallId"}
{":"}
{" "}
{"string"}
{" }"}
|
|
{"59"}
|
{"+"}
|
{" "}
{"|"}
{" { "}
{"type"}
{":"}
{" "}
{"\"tool-output-denied\""}
{"; "}
{"toolCallId"}
{":"}
{" "}
{"string"}
{" }"}
|
|
{"60"}
|
{"+"}
|
{" "}
{"|"}
{" { "}
{"type"}
{":"}
{" "}
{"\"error\""}
{"; "}
{"message"}
{":"}
{" "}
{"string"}
{" }"}
|
|
{"61"}
|
{"+"}
|
{" "}
{"|"}
{" { "}
{"type"}
{":"}
{" "}
{"\"finish\""}
{" };"}
|
|
{"62"}
|
{"+"}
|
{" "}
|
|
{"63"}
|
{"+"}
|
{"type"}
{" "}
{"SseCursor"}
{" "}
{"="}
{" "}
{"SseFrameCursor"}
{"<"}
{"LanggraphFrame"}
{">;"}
|
|
{"64"}
|
{"+"}
|
{" "}
|
|
{"65"}
|
{"+"}
|
{"// sessionId -> 还开着的流 + 卡住的 gated tool_call。key 用 ctx.session.id——session 帧总是"}
|
|
{"66"}
|
{"+"}
|
{"// 每轮第一个到(isNew 时才发),写回 ctx.session.id 之后这个 key 才稳定。gatedCall 存进这个"}
|
|
{"67"}
|
{"+"}
|
{"// Map 而不是留在 drainStream 的局部变量里,是因为 approve/deny 的续读发生在下一次 send() ->"}
|
|
{"68"}
|
{"+"}
|
{"// 一个全新的 drainStream 调用,局部变量活不过这次函数返回,只有 Map 能跨这两次调用带着走。"}
|
|
{"69"}
|
{"+"}
|
{"interface"}
{" "}
{"PendingApproval"}
{" {"}
|
|
{"70"}
|
{"+"}
|
{" "}
{"readonly"}
{" "}
{"cursor"}
{":"}
{" "}
{"SseCursor"}
{";"}
|
|
{"71"}
|
{"+"}
|
{" "}
{"readonly"}
{" "}
{"gatedCall"}
{":"}
{" { "}
{"readonly"}
{" "}
{"toolCallId"}
{":"}
{" "}
{"string"}
{"; "}
{"readonly"}
{" "}
{"name"}
{":"}
{" "}
{"string"}
{"; "}
{"readonly"}
{" "}
{"input"}
{":"}
{" "}
{"unknown"}
{" };"}
|
|
{"72"}
|
{"+"}
|
{"}"}
|
|
{"73"}
|
{"+"}
|
{"const"}
{" "}
{"pendingApprovals"}
{" "}
{"="}
{" "}
{"new"}
{" "}
{"Map"}
{"<"}
{"string"}
{", "}
{"PendingApproval"}
{">();"}
|
|
{"74"}
|
{"+"}
|
{"// 会话续接走「服务端记历史」范式:请求带 session.id(ctx),session 帧回传的 id 用 capture 写回。"}
|
|
{"75"}
|
{"+"}
|
{"const"}
{" "}
{"session"}
{" "}
{"="}
{" "}
{"serverSession"}
{"();"}
|
|
{"76"}
|
{"+"}
|
{" "}
|
|
{"77"}
|
{"+"}
|
{"// LangSmith 的 OtelSpanProcessor 是标准 BatchSpanProcessor(读 OTEL_BSP_SCHEDULE_DELAY,"}
|
|
{"78"}
|
{"+"}
|
{"// tracing.env 已经调到 200ms),但它的调度定时器和\"这一轮 HTTP 请求什么时候返回\"是两条独立"}
|
|
{"79"}
|
{"+"}
|
{"// 时间线——最后一次模型调用(拿到工具结果后生成自然语言回复那次)的 span 经常在 SSE 流已经"}
|
|
{"80"}
|
{"+"}
|
{"// 发完 finish、连接已经关闭之后才真正被导出,niceeval 的本轮收集窗口这时已经关了,消息文本就"}
|
|
{"81"}
|
{"+"}
|
{"// 丢了(实测:图完全跑完、text-delta 帧完整,但 span 数量稳定卡在\"只有第一次模型调用\"那次)。"}
|
|
{"82"}
|
{"+"}
|
{"// 这不是频率问题,加大 schedule delay 也不解决——是\"轮次边界\"和\"批处理导出边界\"这两条时间线"}
|
|
{"83"}
|
{"+"}
|
{"// 天生对不齐。这里在轮次真正结束(拿到 finish 或流自然关闭)后主动等一小段时间,把 niceeval"}
|
|
{"84"}
|
{"+"}
|
{"// 的收集窗口人为拉宽,让最后一批 span 有时间落进来;等 2-3 个 schedule delay 周期足够。"}
|
|
{"85"}
|
{"+"}
|
{"const"}
{" "}
{"OTEL_FLUSH_GRACE_MS"}
{" "}
{"="}
{" "}
{"600"}
{";"}
|
|
{"86"}
|
{"+"}
|
{" "}
|
|
{"87"}
|
{"+"}
|
{"// 只有一个 gated 工具,和 origin src/backend/agent.py 的 GATED_TOOLS 保持一致(帧本身不带"}
|
|
{"88"}
|
{"+"}
|
{"// 工具名,这里跟着写死同一个字符串)。"}
|
|
{"89"}
|
{"+"}
|
{"const"}
{" "}
{"GATED_TOOLS"}
{" "}
{"="}
{" "}
{"new"}
{" "}
{"Set"}
{"(["}
{"\"calculate\""}
{"]);"}
|
|
{"90"}
|
{"+"}
|
{" "}
|
|
{"91"}
|
{"+"}
|
{"interface"}
{" "}
{"GatedCall"}
{" {"}
|
|
{"92"}
|
{"+"}
|
{" "}
{"readonly"}
{" "}
{"toolCallId"}
{":"}
{" "}
{"string"}
{";"}
|
|
{"93"}
|
{"+"}
|
{" "}
{"readonly"}
{" "}
{"name"}
{":"}
{" "}
{"string"}
{";"}
|
|
{"94"}
|
{"+"}
|
{" "}
{"readonly"}
{" "}
{"input"}
{":"}
{" "}
{"unknown"}
{";"}
|
|
{"95"}
|
{"+"}
|
{"}"}
|
|
{"96"}
|
{"+"}
|
{" "}
|
|
{"97"}
|
{"+"}
|
{"/**"}
|
|
{"98"}
|
{"+"}
|
{" * resumeGatedCall:approve/deny 续读时,上一次(turn1)drainStream 调用捕获的 gated 工具调用"}
|
|
{"99"}
|
{"+"}
|
{" * 信息——deny 分支要用它补 action.called,但 turn1 那次调用早就返回了,局部变量活不过一次"}
|
|
{"100"}
|
{"+"}
|
{" * send(),只能靠 pendingApprovals 这个 Map 存着带过来(见下方 send() 的续读分支)。"}
|
|
{"101"}
|
{"+"}
|
{" */"}
|
|
{"102"}
|
{"+"}
|
{"async"}
{" "}
{"function"}
{" "}
{"drainStream"}
{"("}
{"cursor"}
{":"}
{" "}
{"SseCursor"}
{", "}
{"ctx"}
{":"}
{" "}
{"AgentContext"}
{", "}
{"resumeGatedCall"}
{"?:"}
{" "}
{"GatedCall"}
{")"}
{":"}
{" "}
{"Promise"}
{"<"}
{"Turn"}
{"> {"}
|
|
{"103"}
|
{"+"}
|
{" "}
{"const"}
{" "}
{"events"}
{":"}
{" "}
{"StreamEvent"}
{"[] "}
{"="}
{" [];"}
|
|
{"104"}
|
{"+"}
|
{" "}
{"let"}
{" status"}
{":"}
{" "}
{"\"completed\""}
{" "}
{"|"}
{" "}
{"\"failed\""}
{" "}
{"="}
{" "}
{"\"completed\""}
{";"}
|
|
{"105"}
|
{"+"}
|
{" "}
{"let"}
{" messageText "}
{"="}
{" "}
{"\"\""}
{";"}
|
|
{"106"}
|
{"+"}
|
{" "}
{"// gated 工具的 tool-input 先缓着,不立刻 push——approve 分支执行成功后 langsmith 会给一个"}
|
|
{"107"}
|
{"+"}
|
{" "}
{"// 自洽的 \"tool\" 类型 span(call+result 用同一个 spanId,虽然不是真实 tool_call_id,但断言"}
|
|
{"108"}
|
{"+"}
|
{" "}
{"// 只看 name/input/status,不关心 callId 具体值),这时候再补一条用真实 toolCallId 的"}
|
|
{"109"}
|
{"+"}
|
{" "}
{"// action.called 反而会产生一条永远等不到配对 result 的幽灵记录(实测复现过,见"}
|
|
{"110"}
|
{"+"}
|
{" "}
{"// memory/langsmith-dialect-langchain-completion-shape-gap.md)。只有真的被拒绝时"}
|
|
{"111"}
|
{"+"}
|
{" "}
{"// (tool-output-denied 到达)才把缓存的这条连同 action.result 一起 push——被拒绝的调用"}
|
|
{"112"}
|
{"+"}
|
{" "}
{"// 从来不会真的执行,没有 \"tool\" 类型 span,只有这里手动补的这一对是唯一记录。"}
|
|
{"113"}
|
{"+"}
|
{" "}
{"let"}
{" pendingGatedCall"}
{":"}
{" "}
{"GatedCall"}
{" "}
{"|"}
{" "}
{"undefined"}
{" "}
{"="}
{" resumeGatedCall;"}
|
|
{"114"}
|
{"+"}
|
{" "}
|
|
{"115"}
|
{"+"}
|
{" "}
{"const"}
{" "}
{"finalize"}
{" "}
{"="}
{" "}
{"async"}
{" ()"}
{":"}
{" "}
{"Promise"}
{"<"}
{"Turn"}
{"> "}
{"=>"}
{" {"}
|
|
{"116"}
|
{"+"}
|
{" "}
{"if"}
{" (messageText) events."}
{"push"}
{"({ type: "}
{"\"message\""}
{", role: "}
{"\"assistant\""}
{", text: messageText });"}
|
|
{"117"}
|
{"+"}
|
{" "}
{"await"}
{" "}
{"new"}
{" "}
{"Promise"}
{"(("}
{"resolve"}
{") "}
{"=>"}
{" "}
{"setTimeout"}
{"(resolve, "}
{"OTEL_FLUSH_GRACE_MS"}
{"));"}
|
|
{"118"}
|
{"+"}
|
{" "}
{"return"}
{" { status, events };"}
|
|
{"119"}
|
{"+"}
|
{" };"}
|
|
{"120"}
|
{"+"}
|
{" "}
|
|
{"121"}
|
{"+"}
|
{" "}
{"for"}
{" (;;) {"}
|
|
{"122"}
|
{"+"}
|
{" "}
{"const"}
{" "}
{"frame"}
{" "}
{"="}
{" "}
{"await"}
{" cursor."}
{"next"}
{"();"}
|
|
{"123"}
|
{"+"}
|
{" "}
{"if"}
{" (frame "}
{"==="}
{" "}
{"null"}
{") "}
{"break"}
{";"}
|
|
{"124"}
|
{"+"}
|
{" "}
|
|
{"125"}
|
{"+"}
|
{" "}
{"switch"}
{" (frame.type) {"}
|
|
{"126"}
|
{"+"}
|
{" "}
{"case"}
{" "}
{"\"session\""}
{": {"}
|
|
{"127"}
|
{"+"}
|
{" session."}
{"capture"}
{"(ctx, frame.sessionId);"}
|
|
{"128"}
|
{"+"}
|
{" "}
{"break"}
{";"}
|
|
{"129"}
|
{"+"}
|
{" }"}
|
|
{"130"}
|
{"+"}
|
{" "}
{"case"}
{" "}
{"\"text-delta\""}
{": {"}
|
|
{"131"}
|
{"+"}
|
{" messageText "}
{"+="}
{" frame.delta;"}
|
|
{"132"}
|
{"+"}
|
{" "}
{"break"}
{";"}
|
|
{"133"}
|
{"+"}
|
{" }"}
|
|
{"134"}
|
{"+"}
|
{" "}
{"case"}
{" "}
{"\"tool-input\""}
{": {"}
|
|
{"135"}
|
{"+"}
|
{" "}
{"if"}
{" ("}
{"GATED_TOOLS"}
{"."}
{"has"}
{"(frame.name)) {"}
|
|
{"136"}
|
{"+"}
|
{" pendingGatedCall "}
{"="}
{" { toolCallId: frame.toolCallId, name: frame.name, input: frame.input };"}
|
|
{"137"}
|
{"+"}
|
{" }"}
|
|
{"138"}
|
{"+"}
|
{" "}
{"break"}
{";"}
|
|
{"139"}
|
{"+"}
|
{" }"}
|
|
{"140"}
|
{"+"}
|
{" "}
{"case"}
{" "}
{"\"tool-approval-request\""}
{": {"}
|
|
{"141"}
|
{"+"}
|
{" "}
{"if"}
{" ("}
{"!"}
{"ctx.session.id) "}
{"throw"}
{" "}
{"new"}
{" "}
{"Error"}
{"("}
{"\"tool-approval-request 帧到达时 ctx.session.id 还没写回\""}
{");"}
|
|
{"142"}
|
{"+"}
|
{" "}
{"if"}
{" ("}
{"!"}
{"pendingGatedCall "}
{"||"}
{" pendingGatedCall.toolCallId "}
{"!=="}
{" frame.toolCallId) {"}
|
|
{"143"}
|
{"+"}
|
{" "}
{"throw"}
{" "}
{"new"}
{" "}
{"Error"}
{"("}
|
|
{"144"}
|
{"+"}
|
{" "}
{"`tool-approval-request(${"}
{"frame"}
{"."}
{"toolCallId"}
{"})没有对应的 tool-input 帧——协议顺序变了?`"}
{","}
|
|
{"145"}
|
{"+"}
|
{" );"}
|
|
{"146"}
|
{"+"}
|
{" }"}
|
|
{"147"}
|
{"+"}
|
{" pendingApprovals."}
{"set"}
{"(ctx.session.id, { cursor, gatedCall: pendingGatedCall });"}
|
|
{"148"}
|
{"+"}
|
{" "}
{"// 中断前模型可能已经吐了一段前言(比如\"好的,我来算一下\"),这里一并收进这一轮的事件——"}
|
|
{"149"}
|
{"+"}
|
{" "}
{"// 不套 finalize() 的 flush grace:图还停在中断点,没有\"这一轮的 otel 导出\"这回事。"}
|
|
{"150"}
|
{"+"}
|
{" "}
{"if"}
{" (messageText) events."}
{"push"}
{"({ type: "}
{"\"message\""}
{", role: "}
{"\"assistant\""}
{", text: messageText });"}
|
|
{"151"}
|
{"+"}
|
{" events."}
{"push"}
{"({"}
|
|
{"152"}
|
{"+"}
|
{" type: "}
{"\"input.requested\""}
{","}
|
|
{"153"}
|
{"+"}
|
{" request: {"}
|
|
{"154"}
|
{"+"}
|
{" id: frame.toolCallId,"}
|
|
{"155"}
|
{"+"}
|
{" action: "}
{"\"calculate\""}
{","}
|
|
{"156"}
|
{"+"}
|
{" options: [{ id: "}
{"\"approve\""}
{" }, { id: "}
{"\"deny\""}
{" }],"}
|
|
{"157"}
|
{"+"}
|
{" },"}
|
|
{"158"}
|
{"+"}
|
{" });"}
|
|
{"159"}
|
{"+"}
|
{" "}
{"return"}
{" { status: "}
{"\"waiting\""}
{", events };"}
|
|
{"160"}
|
{"+"}
|
{" }"}
|
|
{"161"}
|
{"+"}
|
{" "}
{"case"}
{" "}
{"\"tool-output-denied\""}
{": {"}
|
|
{"162"}
|
{"+"}
|
{" "}
{"// 被拒绝的调用没有 \"tool\" 类型 span(从来没真的执行),这一对 called+result 只有"}
|
|
{"163"}
|
{"+"}
|
{" "}
{"// 这里手动补,是 toolCalls 里唯一的记录——两者用同一个真实 toolCallId,正常配对。"}
|
|
{"164"}
|
{"+"}
|
{" "}
{"if"}
{" (pendingGatedCall "}
{"&&"}
{" pendingGatedCall.toolCallId "}
{"==="}
{" frame.toolCallId) {"}
|
|
{"165"}
|
{"+"}
|
{" events."}
{"push"}
{"({"}
|
|
{"166"}
|
{"+"}
|
{" type: "}
{"\"action.called\""}
{","}
|
|
{"167"}
|
{"+"}
|
{" callId: pendingGatedCall.toolCallId,"}
|
|
{"168"}
|
{"+"}
|
{" name: pendingGatedCall.name,"}
|
|
{"169"}
|
{"+"}
|
{" input: pendingGatedCall.input "}
{"as"}
{" "}
{"JsonValue"}
{","}
|
|
{"170"}
|
{"+"}
|
{" });"}
|
|
{"171"}
|
{"+"}
|
{" pendingGatedCall "}
{"="}
{" "}
{"undefined"}
{";"}
|
|
{"172"}
|
{"+"}
|
{" }"}
|
|
{"173"}
|
{"+"}
|
{" events."}
{"push"}
{"({ type: "}
{"\"action.result\""}
{", callId: frame.toolCallId, status: "}
{"\"rejected\""}
{" });"}
|
|
{"174"}
|
{"+"}
|
{" "}
{"break"}
{";"}
|
|
{"175"}
|
{"+"}
|
{" }"}
|
|
{"176"}
|
{"+"}
|
{" "}
{"case"}
{" "}
{"\"error\""}
{": {"}
|
|
{"177"}
|
{"+"}
|
{" status "}
{"="}
{" "}
{"\"failed\""}
{";"}
|
|
{"178"}
|
{"+"}
|
{" events."}
{"push"}
{"({ type: "}
{"\"error\""}
{", message: frame.message });"}
|
|
{"179"}
|
{"+"}
|
{" "}
{"break"}
{";"}
|
|
{"180"}
|
{"+"}
|
{" }"}
|
|
{"181"}
|
{"+"}
|
{" "}
{"case"}
{" "}
{"\"finish\""}
{": {"}
|
|
{"182"}
|
{"+"}
|
{" "}
{"return"}
{" "}
{"finalize"}
{"();"}
|
|
{"183"}
|
{"+"}
|
{" }"}
|
|
{"184"}
|
{"+"}
|
{" "}
{"// tool-input / tool-output:span 派生已覆盖,不用翻译(见文件头注释)。"}
|
|
{"185"}
|
{"+"}
|
{" "}
{"default"}
{":"}
|
|
{"186"}
|
{"+"}
|
{" "}
{"break"}
{";"}
|
|
{"187"}
|
{"+"}
|
{" }"}
|
|
{"188"}
|
{"+"}
|
{" }"}
|
|
{"189"}
|
{"+"}
|
{" "}
|
|
{"190"}
|
{"+"}
|
{" "}
{"return"}
{" "}
{"finalize"}
{"();"}
|
|
{"191"}
|
{"+"}
|
{"}"}
|
|
{"192"}
|
{"+"}
|
{" "}
|
|
{"193"}
|
{"+"}
|
{"async"}
{" "}
{"function"}
{" "}
{"send"}
{"("}
{"input"}
{":"}
{" "}
{"TurnInput"}
{", "}
{"ctx"}
{":"}
{" "}
{"AgentContext"}
{")"}
{":"}
{" "}
{"Promise"}
{"<"}
{"Turn"}
{"> {"}
|
|
{"194"}
|
{"+"}
|
{" "}
{"const"}
{" "}
{"pending"}
{" "}
{"="}
{" ctx.session.id "}
{"?"}
{" pendingApprovals."}
{"get"}
{"(ctx.session.id) "}
{":"}
{" "}
{"undefined"}
{";"}
|
|
{"195"}
|
{"+"}
|
{" "}
{"if"}
{" (pending) {"}
|
|
{"196"}
|
{"+"}
|
{" pendingApprovals."}
{"delete"}
{"(ctx.session.id"}
{"!"}
{");"}
|
|
{"197"}
|
{"+"}
|
{" "}
{"const"}
{" "}
{"approved"}
{" "}
{"="}
{" input.text."}
{"trim"}
{"()."}
{"toLowerCase"}
{"() "}
{"==="}
{" "}
{"\"approve\""}
{";"}
|
|
{"198"}
|
{"+"}
|
{" "}
{"const"}
{" "}
{"approveRes"}
{" "}
{"="}
{" "}
{"await"}
{" "}
{"appFetch"}
{"("}
|
|
{"199"}
|
{"+"}
|
{" "}
{"\"/api/chat/approve\""}
{","}
|
|
{"200"}
|
{"+"}
|
{" { toolCallId: pending.gatedCall.toolCallId, approved },"}
|
|
{"201"}
|
{"+"}
|
{" ctx.signal,"}
|
|
{"202"}
|
{"+"}
|
{" );"}
|
|
{"203"}
|
{"+"}
|
{" "}
{"if"}
{" ("}
{"!"}
{"approveRes.ok) {"}
|
|
{"204"}
|
{"+"}
|
{" "}
{"throw"}
{" "}
{"new"}
{" "}
{"Error"}
{"("}
{"`POST /api/chat/approve 失败: ${"}
{"approveRes"}
{"."}
{"status"}
{"} ${"}
{"await"}
{" "}
{"approveRes"}
{"."}
{"text"}
{"()"}
{"}`"}
{");"}
|
|
{"205"}
|
{"+"}
|
{" }"}
|
|
{"206"}
|
{"+"}
|
{" "}
{"return"}
{" "}
{"drainStream"}
{"(pending.cursor, ctx, pending.gatedCall);"}
|
|
{"207"}
|
{"+"}
|
{" }"}
|
|
{"208"}
|
{"+"}
|
{" "}
|
|
{"209"}
|
{"+"}
|
{" "}
{"// traceparent 随请求带过去:本轮 span 挂到 niceeval 的 trace 下,并发归属才精确"}
|
|
{"210"}
|
{"+"}
|
{" "}
{"// ——不过 server.py 的 http.server 没接 OTel 服务端埋点,不会读这个头,实际上仍然会"}
|
|
{"211"}
|
{"+"}
|
{" "}
{"// 走时间窗口兜底、自动串行(见 docs/origin-integration.md「并发须知」),这里传只是"}
|
|
{"212"}
|
{"+"}
|
{" "}
{"// 面向未来:应用哪天接了 context 传播就免费生效。"}
|
|
{"213"}
|
{"+"}
|
{" "}
{"const"}
{" "}
{"res"}
{" "}
{"="}
{" "}
{"await"}
{" "}
{"appFetch"}
{"("}
|
|
{"214"}
|
{"+"}
|
{" "}
{"\"/api/chat\""}
{","}
|
|
{"215"}
|
{"+"}
|
{" { message: input.text, sessionId: session."}
{"id"}
{"(ctx) },"}
|
|
{"216"}
|
{"+"}
|
{" ctx.signal,"}
|
|
{"217"}
|
{"+"}
|
{" ctx.telemetry?.headers,"}
|
|
{"218"}
|
{"+"}
|
{" );"}
|
|
{"219"}
|
{"+"}
|
{" "}
{"if"}
{" ("}
{"!"}
{"res.ok "}
{"||"}
{" "}
{"!"}
{"res.body) {"}
|
|
{"220"}
|
{"+"}
|
{" "}
{"throw"}
{" "}
{"new"}
{" "}
{"Error"}
{"("}
{"`POST /api/chat 失败: ${"}
{"res"}
{"."}
{"status"}
{"} ${"}
{"await"}
{" "}
{"res"}
{"."}
{"text"}
{"()."}
{"catch"}
{"(() "}
{"=>"}
{" "}
{"\"\""}
{")"}
{"}`"}
{");"}
|
|
{"221"}
|
{"+"}
|
{" }"}
|
|
{"222"}
|
{"+"}
|
{" "}
{"return"}
{" "}
{"drainStream"}
{"("}
{"sseJsonFrames"}
{"<"}
{"LanggraphFrame"}
{">(res.body), ctx);"}
|
|
{"223"}
|
{"+"}
|
{"}"}
|
|
{"224"}
|
{"+"}
|
{" "}
|
|
{"225"}
|
{"+"}
|
{"export"}
{" "}
{"default"}
{" "}
{"defineAgent"}
{"({"}
|
|
{"226"}
|
{"+"}
|
{" name: "}
{"\"langgraph\""}
{","}
|
|
{"227"}
|
{"+"}
|
{" capabilities: {"}
|
|
{"228"}
|
{"+"}
|
{" "}
{"// 验证过:isNew 时不带 sessionId 开新会话、session 帧回传的 sessionId 写回"}
|
|
{"229"}
|
{"+"}
|
{" "}
{"// ctx.session.id、非 isNew 时带 id 续接同一条历史(LangGraph InMemorySaver,"}
|
|
{"230"}
|
{"+"}
|
{" "}
{"// 进程存活期间有效,见 origin agent.py 头注释)。"}
|
|
{"231"}
|
{"+"}
|
{" conversation: "}
{"true"}
{","}
|
|
{"232"}
|
{"+"}
|
{" "}
{"// 验证过:langsmith 方言(src/o11y/otlp/dialects.ts)从 tool 类型 span 派生完整的"}
|
|
{"233"}
|
{"+"}
|
{" "}
{"// action.called/action.result 配对(callId/name/input/output/status 都有),"}
|
|
{"234"}
|
{"+"}
|
{" "}
{"// get_weather / calculate 每次调用都覆盖,无遗漏。"}
|
|
{"235"}
|
{"+"}
|
{" toolObservability: "}
{"true"}
{","}
|
|
{"236"}
|
{"+"}
|
{" },"}
|
|
{"237"}
|
{"+"}
|
{" events: "}
{"otelEvents"}
{"({ dialects: [otel.langsmith] }),"}
|
|
{"238"}
|
{"+"}
|
{" send,"}
|
|
{"239"}
|
{"+"}
|
{"});"}
|