|
{"1"}
|
{"+"}
|
{"// langgraph 的 adapter:无侵入对接 ../src/backend/server.py —— 自定义 JSON 帧 over SSE"}
|
|
{"2"}
|
{"+"}
|
{"// (server.py 不透传 LangGraph 原生 stream 事件,自己翻译成一套小协议,见其头注释)。"}
|
|
{"3"}
|
{"+"}
|
{"//"}
|
|
{"4"}
|
{"+"}
|
{"// 断言依据全部来自这条流,零 OTel 依赖:"}
|
|
{"5"}
|
{"+"}
|
{"// · `tool-input` → action.called、`tool-output` → action.result(completed,"}
|
|
{"6"}
|
{"+"}
|
{"// 带 isError 时 failed)、`tool-output-denied` → action.result(rejected)——"}
|
|
{"7"}
|
{"+"}
|
{"// 协议帧里本来就有全量工具过程;"}
|
|
{"8"}
|
{"+"}
|
{"// · `text-delta` 累积成完整回复,轮次结束补一条 message 事件;"}
|
|
{"9"}
|
{"+"}
|
{"// · HITL:`tool-approval-request` → input.requested + waiting,停轮现场(还开着的流 +"}
|
|
{"10"}
|
{"+"}
|
{"// 挂起的 toolCallId)用 ctx.session.hold 存住,回答轮 ctx.session.take 取回接着读。"}
|
|
{"11"}
|
{"+"}
|
{"//"}
|
|
{"12"}
|
{"+"}
|
{"// 这是 Tier 1(只接 send):要 `niceeval view` 的调用瀑布图时升 Tier 2,见"}
|
|
{"13"}
|
{"+"}
|
{"// ../../tier2/langgraph/——config 加一行 telemetry、本文件加一段 span 收尾宽限,其它不变。"}
|
|
{"14"}
|
{"+"}
|
{"import"}
{" { defineAgent, sseJsonFrames } "}
{"from"}
{" "}
{"\"niceeval/adapter\""}
{";"}
|
|
{"15"}
|
{"+"}
|
{"import"}
{" "}
{"type"}
{" { AgentContext, SseFrameCursor } "}
{"from"}
{" "}
{"\"niceeval/adapter\""}
{";"}
|
|
{"16"}
|
{"+"}
|
{"import"}
{" "}
{"type"}
{" { JsonValue, StreamEvent, Turn, TurnInput } "}
{"from"}
{" "}
{"\"niceeval\""}
{";"}
|
|
{"17"}
|
{"+"}
|
{" "}
|
|
{"18"}
|
{"+"}
|
{"// 被测应用由你自己按它的方式启动(python server.py / 部署在哪都行),eval 不代管进程、"}
|
|
{"19"}
|
{"+"}
|
{"// 不另开端口。"}
|
|
{"20"}
|
{"+"}
|
{"const"}
{" "}
{"BASE_URL"}
{" "}
{"="}
{" process.env."}
{"LANGGRAPH_URL"}
{" "}
{"??"}
{" "}
{"\"http://127.0.0.1:35000\""}
{";"}
|
|
{"21"}
|
{"+"}
|
{" "}
|
|
{"22"}
|
{"+"}
|
{"async"}
{" "}
{"function"}
{" "}
{"appFetch"}
{"("}
{"path"}
{":"}
{" "}
{"string"}
{", "}
{"body"}
{":"}
{" "}
{"unknown"}
{", "}
{"signal"}
{":"}
{" "}
{"AbortSignal"}
{")"}
{":"}
{" "}
{"Promise"}
{"<"}
{"Response"}
{"> {"}
|
|
{"23"}
|
{"+"}
|
{" "}
{"try"}
{" {"}
|
|
{"24"}
|
{"+"}
|
{" "}
{"return"}
{" "}
{"await"}
{" "}
{"fetch"}
{"("}
{"`${"}
{"BASE_URL"}
{"}${"}
{"path"}
{"}`"}
{", {"}
|
|
{"25"}
|
{"+"}
|
{" method: "}
{"\"POST\""}
{","}
|
|
{"26"}
|
{"+"}
|
{" headers: { "}
{"\"content-type\""}
{": "}
{"\"application/json\""}
{" },"}
|
|
{"27"}
|
{"+"}
|
{" body: "}
{"JSON"}
{"."}
{"stringify"}
{"(body),"}
|
|
{"28"}
|
{"+"}
|
{" signal,"}
|
|
{"29"}
|
{"+"}
|
{" });"}
|
|
{"30"}
|
{"+"}
|
{" } "}
{"catch"}
{" (err) {"}
|
|
{"31"}
|
{"+"}
|
{" "}
{"if"}
{" (signal.aborted) "}
{"throw"}
{" err;"}
|
|
{"32"}
|
{"+"}
|
{" "}
{"throw"}
{" "}
{"new"}
{" "}
{"Error"}
{"("}
|
|
{"33"}
|
{"+"}
|
{" "}
{"`连不上 ${"}
{"BASE_URL"}
{"}${"}
{"path"}
{"}。被测应用在跑吗?先起它(见 README「跑起来」),或设 LANGGRAPH_URL 指向已部署实例。`"}
{","}
|
|
{"34"}
|
{"+"}
|
{" );"}
|
|
{"35"}
|
{"+"}
|
{" }"}
|
|
{"36"}
|
{"+"}
|
{"}"}
|
|
{"37"}
|
{"+"}
|
{" "}
|
|
{"38"}
|
{"+"}
|
{"type"}
{" "}
{"LanggraphFrame"}
{" "}
{"="}
|
|
{"39"}
|
{"+"}
|
{" "}
{"|"}
{" { "}
{"type"}
{":"}
{" "}
{"\"session\""}
{"; "}
{"sessionId"}
{":"}
{" "}
{"string"}
{" }"}
|
|
{"40"}
|
{"+"}
|
{" "}
{"|"}
{" { "}
{"type"}
{":"}
{" "}
{"\"text-delta\""}
{"; "}
{"delta"}
{":"}
{" "}
{"string"}
{" }"}
|
|
{"41"}
|
{"+"}
|
{" "}
{"|"}
{" { "}
{"type"}
{":"}
{" "}
{"\"tool-input\""}
{"; "}
{"toolCallId"}
{":"}
{" "}
{"string"}
{"; "}
{"name"}
{":"}
{" "}
{"string"}
{"; "}
{"input"}
{":"}
{" "}
{"unknown"}
{" }"}
|
|
{"42"}
|
{"+"}
|
{" "}
{"|"}
{" { "}
{"type"}
{":"}
{" "}
{"\"tool-output\""}
{"; "}
{"toolCallId"}
{":"}
{" "}
{"string"}
{"; "}
{"output"}
{":"}
{" "}
{"unknown"}
{"; "}
{"isError"}
{"?:"}
{" "}
{"boolean"}
{" }"}
|
|
{"43"}
|
{"+"}
|
{" "}
{"|"}
{" { "}
{"type"}
{":"}
{" "}
{"\"tool-approval-request\""}
{"; "}
{"toolCallId"}
{":"}
{" "}
{"string"}
{" }"}
|
|
{"44"}
|
{"+"}
|
{" "}
{"|"}
{" { "}
{"type"}
{":"}
{" "}
{"\"tool-output-denied\""}
{"; "}
{"toolCallId"}
{":"}
{" "}
{"string"}
{" }"}
|
|
{"45"}
|
{"+"}
|
{" "}
{"|"}
{" { "}
{"type"}
{":"}
{" "}
{"\"error\""}
{"; "}
{"message"}
{":"}
{" "}
{"string"}
{" }"}
|
|
{"46"}
|
{"+"}
|
{" "}
{"|"}
{" { "}
{"type"}
{":"}
{" "}
{"\"finish\""}
{" };"}
|
|
{"47"}
|
{"+"}
|
{" "}
|
|
{"48"}
|
{"+"}
|
{"type"}
{" "}
{"SseCursor"}
{" "}
{"="}
{" "}
{"SseFrameCursor"}
{"<"}
{"LanggraphFrame"}
{">;"}
|
|
{"49"}
|
{"+"}
|
{" "}
|
|
{"50"}
|
{"+"}
|
{"// HITL 停轮现场:还开着的流 + 挂起的审批 toolCallId。approve/deny 的续读发生在下一次"}
|
|
{"51"}
|
{"+"}
|
{"// send()(一个全新的 drainStream 调用),局部变量活不过这次函数返回——存进 ctx.session.hold,"}
|
|
{"52"}
|
{"+"}
|
{"// 回答轮 ctx.session.take 取回(取到即清除,一次消费)。"}
|
|
{"53"}
|
{"+"}
|
{"interface"}
{" "}
{"PendingApproval"}
{" {"}
|
|
{"54"}
|
{"+"}
|
{" "}
{"readonly"}
{" "}
{"cursor"}
{":"}
{" "}
{"SseCursor"}
{";"}
|
|
{"55"}
|
{"+"}
|
{" "}
{"readonly"}
{" "}
{"toolCallId"}
{":"}
{" "}
{"string"}
{";"}
|
|
{"56"}
|
{"+"}
|
{"}"}
|
|
{"57"}
|
{"+"}
|
{" "}
|
|
{"58"}
|
{"+"}
|
{"async"}
{" "}
{"function"}
{" "}
{"drainStream"}
{"("}
{"cursor"}
{":"}
{" "}
{"SseCursor"}
{", "}
{"ctx"}
{":"}
{" "}
{"AgentContext"}
{")"}
{":"}
{" "}
{"Promise"}
{"<"}
{"Turn"}
{"> {"}
|
|
{"59"}
|
{"+"}
|
{" "}
{"const"}
{" "}
{"events"}
{":"}
{" "}
{"StreamEvent"}
{"[] "}
{"="}
{" [];"}
|
|
{"60"}
|
{"+"}
|
{" "}
{"let"}
{" status"}
{":"}
{" "}
{"\"completed\""}
{" "}
{"|"}
{" "}
{"\"failed\""}
{" "}
{"="}
{" "}
{"\"completed\""}
{";"}
|
|
{"61"}
|
{"+"}
|
{" "}
{"let"}
{" messageText "}
{"="}
{" "}
{"\"\""}
{";"}
|
|
{"62"}
|
{"+"}
|
{" "}
{"// 本次 drain 里见过的 tool-input,按 callId 记名字——tool-approval-request 帧不带工具名,"}
|
|
{"63"}
|
{"+"}
|
{" "}
{"// input.requested 的 action 字段从这里查。"}
|
|
{"64"}
|
{"+"}
|
{" "}
{"const"}
{" "}
{"toolNames"}
{" "}
{"="}
{" "}
{"new"}
{" "}
{"Map"}
{"<"}
{"string"}
{", "}
{"string"}
{">();"}
|
|
{"65"}
|
{"+"}
|
{" "}
|
|
{"66"}
|
{"+"}
|
{" "}
{"const"}
{" "}
{"finalize"}
{" "}
{"="}
{" "}
{"async"}
{" ()"}
{":"}
{" "}
{"Promise"}
{"<"}
{"Turn"}
{"> "}
{"=>"}
{" {"}
|
|
{"67"}
|
{"+"}
|
{" "}
{"if"}
{" (messageText) events."}
{"push"}
{"({ type: "}
{"\"message\""}
{", role: "}
{"\"assistant\""}
{", text: messageText });"}
|
|
{"68"}
|
{"+"}
|
{" "}
{"return"}
{" { status, events };"}
|
|
{"69"}
|
{"+"}
|
{" };"}
|
|
{"70"}
|
{"+"}
|
{" "}
|
|
{"71"}
|
{"+"}
|
{" "}
{"for"}
{" (;;) {"}
|
|
{"72"}
|
{"+"}
|
{" "}
{"const"}
{" "}
{"frame"}
{" "}
{"="}
{" "}
{"await"}
{" cursor."}
{"next"}
{"();"}
|
|
{"73"}
|
{"+"}
|
{" "}
{"if"}
{" (frame "}
{"==="}
{" "}
{"null"}
{") "}
{"break"}
{";"}
|
|
{"74"}
|
{"+"}
|
{" "}
|
|
{"75"}
|
{"+"}
|
{" "}
{"switch"}
{" (frame.type) {"}
|
|
{"76"}
|
{"+"}
|
{" "}
{"case"}
{" "}
{"\"session\""}
{": {"}
|
|
{"77"}
|
{"+"}
|
{" "}
{"// 会话续接走「服务端记历史」范式:session 帧回传的 id 用 ctx.session.capture 写回。"}
|
|
{"78"}
|
{"+"}
|
{" ctx.session."}
{"capture"}
{"(frame.sessionId);"}
|
|
{"79"}
|
{"+"}
|
{" "}
{"break"}
{";"}
|
|
{"80"}
|
{"+"}
|
{" }"}
|
|
{"81"}
|
{"+"}
|
{" "}
{"case"}
{" "}
{"\"text-delta\""}
{": {"}
|
|
{"82"}
|
{"+"}
|
{" messageText "}
{"+="}
{" frame.delta;"}
|
|
{"83"}
|
{"+"}
|
{" "}
{"break"}
{";"}
|
|
{"84"}
|
{"+"}
|
{" }"}
|
|
{"85"}
|
{"+"}
|
{" "}
{"case"}
{" "}
{"\"tool-input\""}
{": {"}
|
|
{"86"}
|
{"+"}
|
{" toolNames."}
{"set"}
{"(frame.toolCallId, frame.name);"}
|
|
{"87"}
|
{"+"}
|
{" events."}
{"push"}
{"({ type: "}
{"\"action.called\""}
{", callId: frame.toolCallId, name: frame.name, input: frame.input "}
{"as"}
{" "}
{"JsonValue"}
{" });"}
|
|
{"88"}
|
{"+"}
|
{" "}
{"break"}
{";"}
|
|
{"89"}
|
{"+"}
|
{" }"}
|
|
{"90"}
|
{"+"}
|
{" "}
{"case"}
{" "}
{"\"tool-output\""}
{": {"}
|
|
{"91"}
|
{"+"}
|
{" events."}
{"push"}
{"({"}
|
|
{"92"}
|
{"+"}
|
{" type: "}
{"\"action.result\""}
{","}
|
|
{"93"}
|
{"+"}
|
{" callId: frame.toolCallId,"}
|
|
{"94"}
|
{"+"}
|
{" output: frame.output "}
{"as"}
{" "}
{"JsonValue"}
{","}
|
|
{"95"}
|
{"+"}
|
{" status: frame.isError "}
{"==="}
{" "}
{"true"}
{" "}
{"?"}
{" "}
{"\"failed\""}
{" "}
{":"}
{" "}
{"\"completed\""}
{","}
|
|
{"96"}
|
{"+"}
|
{" });"}
|
|
{"97"}
|
{"+"}
|
{" "}
{"break"}
{";"}
|
|
{"98"}
|
{"+"}
|
{" }"}
|
|
{"99"}
|
{"+"}
|
{" "}
{"case"}
{" "}
{"\"tool-approval-request\""}
{": {"}
|
|
{"100"}
|
{"+"}
|
{" "}
{"// 停轮:流不关,现场 hold 住;回答轮 take 回来接着读同一条流,不重新发起请求。"}
|
|
{"101"}
|
{"+"}
|
{" "}
{"// 中断前模型可能已经吐了一段前言(比如\"好的,我来算一下\"),一并收进这一轮。"}
|
|
{"102"}
|
{"+"}
|
{" ctx.session."}
{"hold"}
{"<"}
{"PendingApproval"}
{">({ cursor, toolCallId: frame.toolCallId });"}
|
|
{"103"}
|
{"+"}
|
{" "}
{"if"}
{" (messageText) events."}
{"push"}
{"({ type: "}
{"\"message\""}
{", role: "}
{"\"assistant\""}
{", text: messageText });"}
|
|
{"104"}
|
{"+"}
|
{" events."}
{"push"}
{"({"}
|
|
{"105"}
|
{"+"}
|
{" type: "}
{"\"input.requested\""}
{","}
|
|
{"106"}
|
{"+"}
|
{" request: {"}
|
|
{"107"}
|
{"+"}
|
{" id: frame.toolCallId,"}
|
|
{"108"}
|
{"+"}
|
{" action: toolNames."}
{"get"}
{"(frame.toolCallId) "}
{"??"}
{" "}
{"\"tool\""}
{","}
|
|
{"109"}
|
{"+"}
|
{" options: [{ id: "}
{"\"approve\""}
{" }, { id: "}
{"\"deny\""}
{" }],"}
|
|
{"110"}
|
{"+"}
|
{" },"}
|
|
{"111"}
|
{"+"}
|
{" });"}
|
|
{"112"}
|
{"+"}
|
{" "}
{"return"}
{" { status: "}
{"\"waiting\""}
{", events };"}
|
|
{"113"}
|
{"+"}
|
{" }"}
|
|
{"114"}
|
{"+"}
|
{" "}
{"case"}
{" "}
{"\"tool-output-denied\""}
{": {"}
|
|
{"115"}
|
{"+"}
|
{" "}
{"// 被拒绝的调用不执行:action.called 在 tool-input 帧(上一轮)已落,这里只补 rejected"}
|
|
{"116"}
|
{"+"}
|
{" "}
{"// 的 result——同一个 toolCallId,跨轮配对。"}
|
|
{"117"}
|
{"+"}
|
{" events."}
{"push"}
{"({ type: "}
{"\"action.result\""}
{", callId: frame.toolCallId, status: "}
{"\"rejected\""}
{" });"}
|
|
{"118"}
|
{"+"}
|
{" "}
{"break"}
{";"}
|
|
{"119"}
|
{"+"}
|
{" }"}
|
|
{"120"}
|
{"+"}
|
{" "}
{"case"}
{" "}
{"\"error\""}
{": {"}
|
|
{"121"}
|
{"+"}
|
{" status "}
{"="}
{" "}
{"\"failed\""}
{";"}
|
|
{"122"}
|
{"+"}
|
{" events."}
{"push"}
{"({ type: "}
{"\"error\""}
{", message: frame.message });"}
|
|
{"123"}
|
{"+"}
|
{" "}
{"break"}
{";"}
|
|
{"124"}
|
{"+"}
|
{" }"}
|
|
{"125"}
|
{"+"}
|
{" "}
{"case"}
{" "}
{"\"finish\""}
{": {"}
|
|
{"126"}
|
{"+"}
|
{" "}
{"return"}
{" "}
{"finalize"}
{"();"}
|
|
{"127"}
|
{"+"}
|
{" }"}
|
|
{"128"}
|
{"+"}
|
{" "}
{"default"}
{":"}
|
|
{"129"}
|
{"+"}
|
{" "}
{"break"}
{";"}
|
|
{"130"}
|
{"+"}
|
{" }"}
|
|
{"131"}
|
{"+"}
|
{" }"}
|
|
{"132"}
|
{"+"}
|
{" "}
|
|
{"133"}
|
{"+"}
|
{" "}
{"return"}
{" "}
{"finalize"}
{"();"}
|
|
{"134"}
|
{"+"}
|
{"}"}
|
|
{"135"}
|
{"+"}
|
{" "}
|
|
{"136"}
|
{"+"}
|
{"async"}
{" "}
{"function"}
{" "}
{"send"}
{"("}
{"input"}
{":"}
{" "}
{"TurnInput"}
{", "}
{"ctx"}
{":"}
{" "}
{"AgentContext"}
{")"}
{":"}
{" "}
{"Promise"}
{"<"}
{"Turn"}
{"> {"}
|
|
{"137"}
|
{"+"}
|
{" "}
{"// 回答轮:取回停轮现场,把裁决交回应用,接着读同一条流。"}
|
|
{"138"}
|
{"+"}
|
{" "}
{"const"}
{" "}
{"pending"}
{" "}
{"="}
{" ctx.session."}
{"take"}
{"<"}
{"PendingApproval"}
{">();"}
|
|
{"139"}
|
{"+"}
|
{" "}
{"if"}
{" (pending) {"}
|
|
{"140"}
|
{"+"}
|
{" "}
{"// 按 requestId(挂起的 toolCallId)从 input.responses 里对位取裁决,不从 text 猜;"}
|
|
{"141"}
|
{"+"}
|
{" "}
{"// 这里每次只挂一条审批,取第一条即可——多请求并停时按 requestId 对位。"}
|
|
{"142"}
|
{"+"}
|
{" "}
{"const"}
{" "}
{"approved"}
{" "}
{"="}
{" input.responses?.["}
{"0"}
{"]?.optionId "}
{"==="}
{" "}
{"\"approve\""}
{";"}
|
|
{"143"}
|
{"+"}
|
{" "}
{"const"}
{" "}
{"approveRes"}
{" "}
{"="}
{" "}
{"await"}
{" "}
{"appFetch"}
{"("}
|
|
{"144"}
|
{"+"}
|
{" "}
{"\"/api/chat/approve\""}
{","}
|
|
{"145"}
|
{"+"}
|
{" { toolCallId: pending.toolCallId, approved },"}
|
|
{"146"}
|
{"+"}
|
{" ctx.signal,"}
|
|
{"147"}
|
{"+"}
|
{" );"}
|
|
{"148"}
|
{"+"}
|
{" "}
{"if"}
{" ("}
{"!"}
{"approveRes.ok) {"}
|
|
{"149"}
|
{"+"}
|
{" "}
{"throw"}
{" "}
{"new"}
{" "}
{"Error"}
{"("}
{"`POST /api/chat/approve 失败: ${"}
{"approveRes"}
{"."}
{"status"}
{"} ${"}
{"await"}
{" "}
{"approveRes"}
{"."}
{"text"}
{"()"}
{"}`"}
{");"}
|
|
{"150"}
|
{"+"}
|
{" }"}
|
|
{"151"}
|
{"+"}
|
{" "}
{"return"}
{" "}
{"drainStream"}
{"(pending.cursor, ctx);"}
|
|
{"152"}
|
{"+"}
|
{" }"}
|
|
{"153"}
|
{"+"}
|
{" "}
|
|
{"154"}
|
{"+"}
|
{" "}
{"const"}
{" "}
{"res"}
{" "}
{"="}
{" "}
{"await"}
{" "}
{"appFetch"}
{"("}
|
|
{"155"}
|
{"+"}
|
{" "}
{"\"/api/chat\""}
{","}
|
|
{"156"}
|
{"+"}
|
{" { message: input.text, sessionId: ctx.session.id },"}
|
|
{"157"}
|
{"+"}
|
{" ctx.signal,"}
|
|
{"158"}
|
{"+"}
|
{" );"}
|
|
{"159"}
|
{"+"}
|
{" "}
{"if"}
{" ("}
{"!"}
{"res.ok "}
{"||"}
{" "}
{"!"}
{"res.body) {"}
|
|
{"160"}
|
{"+"}
|
{" "}
{"throw"}
{" "}
{"new"}
{" "}
{"Error"}
{"("}
{"`POST /api/chat 失败: ${"}
{"res"}
{"."}
{"status"}
{"} ${"}
{"await"}
{" "}
{"res"}
{"."}
{"text"}
{"()."}
{"catch"}
{"(() "}
{"=>"}
{" "}
{"\"\""}
{")"}
{"}`"}
{");"}
|
|
{"161"}
|
{"+"}
|
{" }"}
|
|
{"162"}
|
{"+"}
|
{" "}
{"return"}
{" "}
{"drainStream"}
{"("}
{"sseJsonFrames"}
{"<"}
{"LanggraphFrame"}
{">(res.body), ctx);"}
|
|
{"163"}
|
{"+"}
|
{"}"}
|
|
{"164"}
|
{"+"}
|
{" "}
|
|
{"165"}
|
{"+"}
|
{"export"}
{" "}
{"default"}
{" "}
{"defineAgent"}
{"({"}
|
|
{"166"}
|
{"+"}
|
{" name: "}
{"\"langgraph\""}
{","}
|
|
{"167"}
|
{"+"}
|
{" send,"}
|
|
{"168"}
|
{"+"}
|
{"});"}
|