","\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":1027},"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",1786625929,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",[1171,1172,1173,1174,1175,1176,1177,1178,1179,1180,1181,1182,1183],"navigation",{"_1048":1049,"_1132":1133,"_1134":1135,"_1136":1137,"_1138":1139,"_1140":1141,"_68":1142},"sources",[],"viewer","meta",{"_1125":1126,"_1127":1128,"_1129":72,"_1037":26,"_1130":1120,"_1131":26,"_1043":956,"_1044":956},"branches",[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,1124],"tags",[1063,1064,1065,1066],"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",[1154,1155,1156],"documents",{"_1150":1151,"_1152":536},"code",{"_1147":1148,"_1149":42},"automations",{"_1145":814,"_1146":-5},"delivery",{"_1143":956,"_1144":-5},"04zvKQ8QOrDUF8TO1Ovz0Zy8_TT","releases","applications","workflows","deployments","commits",1000,"changes","counts",{"_1153":536},"total","issue",{"_1157":1149,"_1017":1169,"_35":1149,"_1160":1170,"_1046":1162,"_1163":26,"_1164":1162,"_1165":42},{"_1157":1166,"_1017":1167,"_35":1166,"_1160":1168,"_1046":1162,"_1163":26,"_1164":1162,"_1165":956},{"_1157":1158,"_1017":1159,"_35":1158,"_1160":1161,"_1046":1162,"_1163":26,"_1164":1162,"_1165":536},"id","issues","Issues","filters",{},true,"saved","pinnable","count","tasks","Tasks",{},"Changes",{},{"_1157":1149,"_1017":1169,"_35":1149,"_1160":1214,"_1046":1162,"_1163":26,"_1164":1162},{"_1157":1166,"_1017":1167,"_35":1166,"_1160":1213,"_1046":1162,"_1163":26,"_1164":1162},{"_1157":1158,"_1017":1159,"_35":1158,"_1160":1212,"_1046":1162,"_1163":26,"_1164":1162},{"_1157":1209,"_1017":1210,"_35":1209,"_1160":1211,"_1046":26,"_1163":26,"_1164":1162},{"_1157":1206,"_1017":1207,"_35":1206,"_1160":1208,"_1046":26,"_1163":26,"_1164":1162},{"_1157":1145,"_1017":1204,"_35":1138,"_1160":1205,"_1046":26,"_1163":26,"_1164":1162},{"_1157":1146,"_1017":1201,"_35":1202,"_1160":1203,"_1046":26,"_1163":26,"_1164":1162},{"_1157":1143,"_1017":1199,"_35":1143,"_1160":1200,"_1046":26,"_1163":26,"_1164":1162},{"_1157":1195,"_1017":1196,"_35":1197,"_1160":1198,"_1046":26,"_1163":26,"_1164":1162},{"_1157":1134,"_1017":1193,"_35":1134,"_1160":1194,"_1046":26,"_1163":26,"_1164":26},{"_1157":1190,"_1017":1191,"_35":1190,"_1160":1192,"_1046":26,"_1163":26,"_1164":26},{"_1157":1187,"_1017":1188,"_35":1187,"_1160":1189,"_1046":26,"_1163":26,"_1164":26},{"_1157":1184,"_1017":1185,"_35":1184,"_1160":1186,"_1046":26,"_1163":26,"_1164":26},"decisions","Decisions",{},"changelog","Changelog",{},"roadmap","Roadmap",{},"Documents",{},"activity","Activity","insights",{},"Releases",{},"Deployments","automations/deployments",{},"Workflows",{},"discussions","Discussions",{},"goals","Goals",{},{},{},{},"groups","user","agents",[],"now",1794435739231,"sidebar","expanded"]