","\t\t\t/>","\t\t\t\t\t: undefined}","\t\t\t\t\t? turn","\t\t\t\tworking={connected && synchronized.current === wire && turn && !turn.responded","\t\t\t\tworking={connected && busy && !responded}","\t\t\t\tqueued={queue}","\t\t\t\tonWithdraw={id => wire?.send(\"chat:unqueue\", { id })}","\t\t\t\thandle={handle}",92,103,[672,673,674,675,676,677,678,679],{"_68":69,"_70":682},{"_68":69,"_70":686},{"_68":69,"_70":685},{"_68":43,"_70":684},{"_68":41,"_70":683},{"_68":69,"_70":682},{"_68":69,"_70":681},{"_68":69,"_70":680},"\t\t];","\t\t\twire.on(\"chat:queue\", frame => setQueue(frame.waiting)),","\t\t\t}),","\t\t\t\tsetTurn(frame.turn);","\t\t\t\tif (!frame.busy) setResponded(false);","\t\t\t\tsetBusy(frame.busy);","\t\t\twire.on(\"chat:state\", frame => {",72,82,[690,691,692,693,694,695,696],{"_68":69,"_70":702},{"_68":69,"_70":701},{"_68":69,"_70":700},{"_68":41,"_70":699},{"_68":69,"_70":682},{"_68":69,"_70":698},{"_68":69,"_70":697},"\t\t\t\tsetEntries(current => {","\t\t\twire.on(\"chat:tool\", frame => {","\t\t\t\tresponse(true, frame.text);","\t\t\t\t);","\t\t\t\t\t)","\t\t\t\t\t\tentry.id === frame.id ? { ...entry, text: entry.text + frame.text } : entry",64,74,[706,707,708,709,710,711,712,713],{"_68":69,"_70":720},{"_68":69,"_70":719},{"_68":69,"_70":718},{"_68":43,"_70":717},{"_68":41,"_70":716},{"_68":69,"_70":682},{"_68":69,"_70":715},{"_68":69,"_70":714},"\t\t\t\tsetEntries(current =>","\t\t\twire.on(\"chat:delta\", frame => {","\t\t\t\tresponse(frame.entry.author.kind === \"agent\", frame.entry.text);","\t\t\t\tif (frame.entry.author.kind === \"agent\") setResponded(true);","\t\t\t\t});","\t\t\t\t\treturn next;","\t\t\t\t\tnext[index] = frame.entry;",31,26,36,[725,726,727,728,729,730,731,732,733,734,735,736,737,738,739,740,741,742,743,744,745,746,747,748,749,750,751,752,753,754,755,756,757,758,759,760,761,762],{"_68":69,"_70":794},{"_68":69,"_70":793},{"_68":69,"_70":792},{"_68":43,"_70":791},{"_68":41,"_70":790},{"_68":69,"_70":789},{"_68":41,"_70":788},{"_68":41,"_70":72},{"_68":41,"_70":787},{"_68":41,"_70":786},{"_68":41,"_70":785},{"_68":69,"_70":72},{"_68":69,"_70":784},{"_68":69,"_70":783},{"_68":69,"_70":782},{"_68":69,"_70":781},{"_68":69,"_70":780},{"_68":41,"_70":779},{"_68":41,"_70":778},{"_68":41,"_70":777},{"_68":41,"_70":776},{"_68":69,"_70":72},{"_68":69,"_70":775},{"_68":69,"_70":774},{"_68":69,"_70":773},{"_68":69,"_70":772},{"_68":69,"_70":771},{"_68":41,"_70":770},{"_68":69,"_70":769},{"_68":69,"_70":768},{"_68":69,"_70":767},{"_68":69,"_70":766},{"_68":69,"_70":685},{"_68":43,"_70":765},{"_68":41,"_70":683},{"_68":69,"_70":682},{"_68":69,"_70":764},{"_68":69,"_70":763},"\t\t\t\tif (loaded && !seen.has(frame.entry.id)) {","\t\t\twire.on(\"chat:message\", frame => {","\t\t\t\tsetResponded(frame.entries.at(-1)?.author.kind === \"agent\");","\t\t\t\tsetQueue(frame.queued);","\t\t\t\tsetArrived(new Set());","\t\t\t\tsetEntries(frame.entries);","\t\t\t\tseen = new Set(frame.entries.map(entry => entry.id));","\t\t\t\tsynchronized.current = wire;","\t\t\t\tloaded = true;","\t\t\twire.on(\"chat:history\", frame => {","\t\tlet off = [","\t\t// the reducer here has to be additive rather than replacing.","\t\t// Streaming arrives as deltas against an entry already in the list, so","\t\t};","\t\t\tsetTurn(current => current && !current.responded ? { ...current, responded: true } : current);","\t\t\tif (!agent || !value.trim()) return;","\t\tlet response = (agent: boolean, value: string) => {","\t\tlet seen = new Set();","\t\tlet loaded = false;","\t\t// History seeds `seen`; only later message frames are arrivals.","\t\tif (!wire) return;","\tuseEffect(() => {","\tif (!connected) synchronized.current = undefined;","\t// previous socket's transient turn project into that gap.","\t// A socket is connected before its fresh history arrives. Do not let a","\tlet synchronized = useRef(undefined);","\tlet [text, setText] = useState(\"\");","\tlet [turn, setTurn] = useState();","\tlet [responded, setResponded] = useState(false);","\tlet [busy, setBusy] = useState(false);","\tlet [queue, setQueue] = useState([]);","\tlet [arrived, setArrived] = useState>(new Set());",[796,797,798,799,800,801,802,803],{"_68":69,"_70":808},{"_68":69,"_70":807},{"_68":69,"_70":72},{"_68":43,"_70":806},{"_68":41,"_70":805},{"_68":69,"_70":72},{"_68":69,"_70":804},{"_68":69,"_70":72},"import { addressed } from \"@chopin/protocol/address\";","import { useEffect, useRef, useState } from \"react\";","import { useEffect, useState } from \"react\";"," */"," * looks like a prompt and being met with silence.","4a158b01","8213072e","apps/server/src/chat/service.ts",{"_120":952,"_122":123},{"_120":951,"_122":123},3,[816,817,818,819,820,821,822],{"_49":929,"_51":52,"_53":929,"_55":52,"_57":930},{"_49":907,"_51":137,"_53":907,"_55":42,"_57":908},{"_49":892,"_51":137,"_53":893,"_55":56,"_57":894},{"_49":875,"_51":56,"_53":876,"_55":56,"_57":877},{"_49":853,"_51":81,"_53":854,"_55":855,"_57":856},{"_49":837,"_51":137,"_53":838,"_55":56,"_57":839},{"_49":823,"_51":137,"_53":824,"_55":56,"_57":825},555,566,[826,827,828,829,830,831,832],{"_68":69,"_70":836},{"_68":69,"_70":835},{"_68":69,"_70":718},{"_68":41,"_70":834},{"_68":69,"_70":249},{"_68":69,"_70":72},{"_68":69,"_70":833},"\t\t\tchat.writing = undefined;","\t\t\t\tresponded(chat, server, room, content);","\t\t\t\t\tts: now(),","\t\t\t\t\ttext: content,",547,557,[840,841,842,843,844,845,846],{"_68":69,"_70":852},{"_68":69,"_70":851},{"_68":69,"_70":850},{"_68":41,"_70":834},{"_68":69,"_70":849},{"_68":69,"_70":848},{"_68":69,"_70":847},"\t\t\t\tsay(chat, server, room, {","\t\t\t\t// No deltas arrived — a short reply the model did not stream.","\t\t\t} else if (content.trim()) {","\t\t\t\tbroadcast(server, room, { kind: \"chat:message\", ts: 0, entry });","\t\t\t\tdelete entry.streaming;","\t\t\t\tentry.text = content || entry.text;",528,536,12,[857,858,859,860,861,862,863,864,865,866,867,868],{"_68":69,"_70":835},{"_68":69,"_70":381},{"_68":69,"_70":718},{"_68":41,"_70":874},{"_68":69,"_70":250},{"_68":69,"_70":249},{"_68":69,"_70":873},{"_68":69,"_70":872},{"_68":41,"_70":871},{"_68":69,"_70":870},{"_68":69,"_70":869},{"_68":69,"_70":72},"\t\t}","\t\t\treturn;","\t\t\tresponded(chat, server, room, deltaContent);","\t\t\tbroadcast(server, room, { kind: \"chat:delta\", ts: 0, id: messageId, text: deltaContent });","\t\t\tentry.text += deltaContent;","\t\t\t\tresponded(chat, server, room, deltaContent);",396,404,[878,879,880,881,882,883,884,885],{"_68":69,"_70":891},{"_68":69,"_70":72},{"_68":69,"_70":890},{"_68":43,"_70":889},{"_68":41,"_70":888},{"_68":69,"_70":887},{"_68":69,"_70":886},{"_68":69,"_70":72},"\tstate(chat, server, room);","\tchat.acting = thread;","\tchat.turn = { id: ulid(), handle, started: now(), responded: false };","\tchat.turn = handle;","\tchat.busy = true;","\tlet { chat, plan, room, server } = context;",176,183,[895,896,897,898,899,900,901],{"_68":69,"_70":906},{"_68":69,"_70":905},{"_68":69,"_70":904},{"_68":41,"_70":903},{"_68":69,"_70":902},{"_68":69,"_70":246},{"_68":69,"_70":530},"\t\tqueued: visible(chat),","\t\t...(chat.turn ? { turn: chat.turn } : {}),","\t\tbusy: chat.busy,","\t\tentries: chat.entries,","\t\tts: 0,",139,[909,910,911,912,913,914,915,916,917,918,919,920,921],{"_68":69,"_70":246},{"_68":69,"_70":530},{"_68":69,"_70":72},{"_68":41,"_70":928},{"_68":41,"_70":927},{"_68":41,"_70":926},{"_68":41,"_70":925},{"_68":41,"_70":886},{"_68":41,"_70":530},{"_68":41,"_70":72},{"_68":69,"_70":924},{"_68":69,"_70":923},{"_68":69,"_70":922}," *"," * The queue as clients see it.","/**","\tchat.turn.responded = true;","\tif (!chat.turn || chat.turn.responded || !text.trim()) return;","function responded(chat: Chat, server: Server, room: string, text: string): void {","/** Tool activity is useful context, but only visible Planner prose ends the projection. */",70,[931,932,933,934,935,936,937,938,939,940],{"_68":69,"_70":950},{"_68":69,"_70":949},{"_68":69,"_70":948},{"_68":43,"_70":947},{"_68":43,"_70":946},{"_68":41,"_70":945},{"_68":41,"_70":944},{"_68":69,"_70":943},{"_68":69,"_70":942},{"_68":69,"_70":941},"\t *","\t * The comment thread the running turn is acting on.","\t/**","\tturn?: Wire.Turn;","\t/** The transient lifecycle of the running Planner turn. */","\tturn?: string;","\t/** Whose message the running turn is answering. */","\tbusy: boolean;","\topening?: Promise;","\t/** In flight while the session is being opened, so a second prompt waits. */","31c95e9a","87f88aa6","apps/server/src/chat/service.test.ts",{"_120":1003,"_122":123},{"_120":1002,"_122":123},0,[958],{"_49":959,"_51":137,"_53":959,"_55":722,"_57":960},78,[961,962,963,964,965,966,967,968,969,970,971,972,973,974,975,976,977,978,979,980,981,982,983,984,985,986],{"_68":69,"_70":530},{"_68":69,"_70":72},{"_68":69,"_70":1001},{"_68":41,"_70":1000},{"_68":41,"_70":988},{"_68":41,"_70":999},{"_68":41,"_70":998},{"_68":41,"_70":997},{"_68":41,"_70":996},{"_68":41,"_70":995},{"_68":41,"_70":776},{"_68":41,"_70":987},{"_68":41,"_70":72},{"_68":41,"_70":994},{"_68":41,"_70":992},{"_68":41,"_70":72},{"_68":41,"_70":993},{"_68":41,"_70":992},{"_68":41,"_70":72},{"_68":41,"_70":991},{"_68":41,"_70":990},{"_68":41,"_70":246},{"_68":41,"_70":72},{"_68":69,"_70":989},{"_68":69,"_70":988},{"_68":69,"_70":987},"\t\tlet { context } = room(chat);","\t\tlet chat = create();","\tit(\"becomes one entry, not one per event\", () => {","\t\texpect(chat.turn?.responded).toBe(true);","\t\ttranslate(context, delta(\"m1\", \"I found it.\"));","\t\texpect(chat.turn?.responded).toBe(false);","\t\ttranslate(context, delta(\"m1\", \" \"));","\t\ttranslate(context, tool(\"tool.execution_start\", { toolCallId: \"t1\", toolName: \"grep\" }));","\t\t\tresponded: false,","\t\t\tstarted: 1_700_000_000,","\t\t\thandle: \"ana\",","\t\t\tid: \"turn-1\",","\t\tchat.turn = {","\tit(\"counts only non-empty Planner prose as the turn response\", () => {","describe(\"a streamed message\", () => {","444b6e3f","2ccca445","parents",[20],"author",{"_1017":1018,"_1019":1020,"_1025":1026},"committer",{"_1017":1018,"_1019":1020,"_1025":1026},"message","Fix Planner working turn lifecycle","signature","subject","authors",[1016],{"_1017":1018,"_1019":1020,"_1021":1022,"_1023":1024},"name","Maggie Appleton","email","5599295+MaggieAppleton@users.noreply.github.com","login","MaggieAppleton","avatarUrl","https://avatars.githubusercontent.com/u/5599295?v=4","time",1786547649,"documentNavigation","repo","githubnext/chopin","repoId","7d1a8ac3-35b0-4dea-85d4-06a980f3bada","ownerId","org:89615882","site","nexthub","private","admin","settings","maintainer","triage","starred","stars","watchers","watching","pinned","notify","views",[1170,1171,1172,1173,1174,1175,1176,1177,1178,1179,1180,1181,1182],"navigation",{"_1047":1048,"_1131":1132,"_1133":1134,"_1135":1136,"_1137":1138,"_1139":1140,"_68":1141},"sources",[],"viewer","meta",{"_1124":1125,"_1126":1127,"_1128":72,"_1036":26,"_1129":1119,"_1130":26,"_1042":956,"_1043":956},"branches",[1066,1067,1068,1069,1070,1071,1072,1073,1074,1075,1076,1077,1078,1079,1080,1081,1082,1083,1084,1085,1086,1087,1088,1089,1090,1091,1092,1093,1094,1095,1096,1097,1098,1099,1100,1101,1102,1103,1104,1105,1106,1107,1108,1109,1110,1111,1112,1113,1114,1115,1116,1117,1118,1119,1120,1121,1122,1123],"tags",[1062,1063,1064,1065],"cloneUrl","https://git.nexthub.sh/githubnext/chopin.git","color-controls-slice-1","color-controls-slice-2","color-controls-slice-3","color-controls-slice-4","Krzysztof-Cieslak-patch-1","Krzysztof-Cieslak-patch-2","Maggie/app-preview-toolkit","Maggie/ci-playwright-install-timeout","Maggie/collaborative-visual-decision","Maggie/design-audit","Maggie/generic-visual-decision-runtime","Maggie/impeccable-chopin-metadata","Maggie/jev-chat-product","Maggie/jev-composed-assessment","Maggie/native-document-layouts","Maggie/openui-composition-product","Maggie/openui-composition-trial","Maggie/planner-visual-authoring","Maggie/planner-visual-requests","Maggie/visual-selection-eval","artifacts/pr-419-live-preview-20261009","automation/pr-maintenance-state","automation/use-effect/callout-disabled-picker-8cf9e49ba5c09471","automation/use-effect/collaboration-options-ref-4e3a5a08a879a5ae","automation/use-effect/room-workspace-effective-access-a57d40866c71bed0","chore/bun-1.4.2","color-controls","color-controls-plan","comments","design-pr-assets","design/archived-decisions-badge","design/channel-route-remount","design/chat-decision-entry","design/conversation-analysis-markers","design/decision-evidence","design/settled-line-icon","dev/integration","diagram-step-controls","feat/liveapp-frontend-pilot","feat/local-experiments","feat/local-launcher-tracer","fix/autolink-mdx-crash","github-pills/2-pills","github-pills/3-hover-card","maggie/app-preview-toolkit","maggie/ci-playwright-install-timeout","maggie/collaborative-visual-decision","maggie/design-audit","maggie/generic-visual-decision-runtime","maggie/impeccable-chopin-metadata","maggie/jev-composed-assessment","maggie/native-document-layouts","maggie/openui-composition-product","maggie/openui-composition-trial","maggie/planner-visual-authoring","maggie/planner-visual-requests","maggie/visual-selection-eval","main","plain-text-fence-chrome","tokens/09-copy","wireframes/2-renderer","wireframes/3-planner","description","Let's compose rich plans together","owner","githubnext","section","head","empty","pins",[1153,1154,1155],"documents",{"_1149":1150,"_1151":536},"code",{"_1146":1147,"_1148":42},"automations",{"_1144":814,"_1145":-5},"delivery",{"_1142":956,"_1143":-5},"04zvKQ8QOrDUF8TO1Ovz0Zy8_TT","releases","applications","workflows","deployments","commits",1000,"changes","counts",{"_1152":536},"total","issue",{"_1156":1148,"_1017":1168,"_35":1148,"_1159":1169,"_1045":1161,"_1162":26,"_1163":1161,"_1164":42},{"_1156":1165,"_1017":1166,"_35":1165,"_1159":1167,"_1045":1161,"_1162":26,"_1163":1161,"_1164":956},{"_1156":1157,"_1017":1158,"_35":1157,"_1159":1160,"_1045":1161,"_1162":26,"_1163":1161,"_1164":536},"id","issues","Issues","filters",{},true,"saved","pinnable","count","tasks","Tasks",{},"Changes",{},{"_1156":1148,"_1017":1168,"_35":1148,"_1159":1213,"_1045":1161,"_1162":26,"_1163":1161},{"_1156":1165,"_1017":1166,"_35":1165,"_1159":1212,"_1045":1161,"_1162":26,"_1163":1161},{"_1156":1157,"_1017":1158,"_35":1157,"_1159":1211,"_1045":1161,"_1162":26,"_1163":1161},{"_1156":1208,"_1017":1209,"_35":1208,"_1159":1210,"_1045":26,"_1162":26,"_1163":1161},{"_1156":1205,"_1017":1206,"_35":1205,"_1159":1207,"_1045":26,"_1162":26,"_1163":1161},{"_1156":1144,"_1017":1203,"_35":1137,"_1159":1204,"_1045":26,"_1162":26,"_1163":1161},{"_1156":1145,"_1017":1200,"_35":1201,"_1159":1202,"_1045":26,"_1162":26,"_1163":1161},{"_1156":1142,"_1017":1198,"_35":1142,"_1159":1199,"_1045":26,"_1162":26,"_1163":1161},{"_1156":1194,"_1017":1195,"_35":1196,"_1159":1197,"_1045":26,"_1162":26,"_1163":1161},{"_1156":1133,"_1017":1192,"_35":1133,"_1159":1193,"_1045":26,"_1162":26,"_1163":26},{"_1156":1189,"_1017":1190,"_35":1189,"_1159":1191,"_1045":26,"_1162":26,"_1163":26},{"_1156":1186,"_1017":1187,"_35":1186,"_1159":1188,"_1045":26,"_1162":26,"_1163":26},{"_1156":1183,"_1017":1184,"_35":1183,"_1159":1185,"_1045":26,"_1162":26,"_1163":26},"decisions","Decisions",{},"changelog","Changelog",{},"roadmap","Roadmap",{},"Documents",{},"activity","Activity","insights",{},"Releases",{},"Deployments","automations/deployments",{},"Workflows",{},"discussions","Discussions",{},"goals","Goals",{},{},{},{},"groups","user","agents",[],"now",1794439476790,"sidebar","expanded"]