[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10,"_11":12},"actionData","errors","root",{"_228":-5,"_231":232,"_233":234},"routes/shell",{"_40":41,"_227":-5,"_228":-5,"_229":230},"routes/repo",{"_33":-7,"_34":35,"_36":37,"_38":39,"_40":41,"_42":31,"_43":31,"_44":31,"_45":31,"_46":31,"_47":31,"_48":49,"_50":49,"_51":31,"_52":-7,"_53":-7,"_54":55,"_56":57,"_58":59,"_60":-5,"_61":62,"_63":64,"_65":66,"_67":68},"routes/repo.blob",{"_13":14,"_15":16,"_17":18,"_19":20,"_21":14,"_22":23,"_24":-5,"_25":26,"_27":28,"_28":29,"_30":31,"_32":14},"ref","1c1f09cd8e7a04b1dfebf2d2e8a4d0bdbfcb570a","path","apps/server/src/harness/atomic/full.ts","oid","557ae650b17d8ba907493cb38cb85a637c9588e7","size",9996,"commit","mounts",[],"source","plain",{"_13":14,"_15":16},"kind","text","import type {\n\tExtensionAPI,\n\tExtensionFactory,\n\tHostInput,\n\tWorkflowActivitySubscription,\n\tWorkflowLifecycleEvent,\n\tWorkflowRootActivity,\n} from \"@bastani/atomic\";\nimport type { Chat as Wire } from \"@chopin/protocol\";\n\n/**\n * Root workflow runs a Planner session owns: still live, or paused and\n * resumable, plus what each run's card shows.\n */\nexport type PlannerRuns = { active: string[]; paused: string[]; cards: Wire.Run[] };\n\nexport type FullPlanner = {\n\tcwd: string;\n\thumanInput: HostInput;\n\t/** Latest known runs; absent until Atomic reports its workflow activity as ready. */\n\truns?: PlannerRuns;\n\t/** Called with every change to `runs`. */\n\tonRuns?: (runs: PlannerRuns) => void;\n\t/** Runs the session's own `workflow` tool without a model turn; set once the session exists. */\n\tcontrol?: (params: WorkflowControl) => Promise;\n};\nexport type WorkflowControl =\n\t| { action: \"pause\"; all: true }\n\t| { action: \"quit\"; runId: string }\n\t| { action: \"resume\"; runId: string };\n\n/** The run-control outcome Atomic reports: `noop` means nothing changed, for example a run whose only stage waits on input. */\nexport type WorkflowControlResult = { status: string; message: string };\n\nlet planners = new Map();\n\n/** The text of a tool result, for errors. */\nfunction resultText(content: readonly { type: string; text?: string }[]): string {\n\treturn content.map(part => part.type === \"text\" ? part.text ?? \"\" : \"\").join(\"\\n\").trim();\n}\n\n/**\n * Runs one run-control action through the session's `workflow` tool with a real\n * tool context, so the outcome comes back as a result rather than a UI notice.\n */\nexport async function controlWorkflows(\n\tsession: {\n\t\tgetToolDefinition(\n\t\t\tname: string,\n\t\t): { execute: (...args: never[]) => Promise } | undefined;\n\t\textensionRunner: { createToolContext(id: string, signal: AbortSignal | undefined): unknown };\n\t},\n\tparams: WorkflowControl,\n): Promise {\n\tlet tool = session.getToolDefinition(\"workflow\");\n\tif (!tool) throw new Error(\"The Planner session has no workflow tool.\");\n\tlet id = `chopin-${params.action}-${crypto.randomUUID()}`;\n\tlet signal = AbortSignal.timeout(30_000);\n\tlet execute = tool.execute as (\n\t\tid: string,\n\t\tparams: WorkflowControl,\n\t\tsignal: AbortSignal,\n\t\tonUpdate: undefined,\n\t\tctx: unknown,\n\t) => Promise<\n\t\t{ content?: { type: string; text?: string }[]; isError?: boolean; details?: unknown }\n\t>;\n\tlet result = await execute(\n\t\tid,\n\t\tparams,\n\t\tsignal,\n\t\tundefined,\n\t\tsession.extensionRunner.createToolContext(id, signal),\n\t);\n\tlet text = resultText(result.content ?? []);\n\tlet details = typeof result.details === \"object\" && result.details !== null\n\t\t? result.details as { status?: unknown; message?: unknown }\n\t\t: {};\n\tlet status = typeof details.status === \"string\"\n\t\t? details.status\n\t\t: /\"status\"\\s*:\\s*\"(\\w+)\"/.exec(text)?.[1] ?? \"\";\n\tif (result.isError === true || status === \"failed\" || status === \"error\") {\n\t\tthrow new Error(`workflow ${params.action} failed: ${text.slice(0, 500)}`);\n\t}\n\treturn { status, message: typeof details.message === \"string\" ? details.message : text };\n}\n\n/**\n * Pauses every run a Planner session owns. Atomic pauses running and pending\n * stages only, so a run whose live stage waits on a question has nothing to\n * pause; it is quit instead, which keeps it resumable, withdraws its question\n * from Decisions, and asks it again on resume.\n */\nexport async function pauseOwnedRuns(\n\tcontrol: (params: WorkflowControl) => Promise,\n\tlive: readonly string[],\n): Promise {\n\tlet runs = [...live];\n\tlet paused = await control({ action: \"pause\", all: true });\n\tif (paused.status === \"paused\") return;\n\tfor (let runId of runs) {\n\t\tlet quit = await control({ action: \"quit\", runId });\n\t\tif (quit.status !== \"paused\" && quit.status !== \"partial\") {\n\t\t\tthrow new Error(`Run ${runId} could not be paused: ${quit.message || paused.message}`);\n\t\t}\n\t}\n}\n\n/** Every Atomic Planner session is registered; background workers never are. */\nexport function registerFullPlanner(sessionId: string, planner: FullPlanner): () => void {\n\tif (planners.has(sessionId)) throw new Error(\"Atomic Planner session is already registered\");\n\tplanners.set(sessionId, planner);\n\treturn () => {\n\t\tif (planners.get(sessionId) === planner) planners.delete(sessionId);\n\t};\n}\n\nexport function fullPlanner(sessionId: string): FullPlanner | undefined {\n\treturn planners.get(sessionId);\n}\n\n/** Working and blocked roots are live; an idle root is paused only when Atomic says so. */\nexport function classifyRuns(roots: Iterable): Omit {\n\tlet runs = { active: [] as string[], paused: [] as string[] };\n\tfor (let root of roots) {\n\t\tif (root.state === \"working\" || root.state === \"blocked\") runs.active.push(root.rootRunId);\n\t\telse if (root.reason === \"paused\") runs.paused.push(root.rootRunId);\n\t}\n\treturn runs;\n}\n\ntype Card = Wire.Run & { stageIndex: Map; prompts: Set };\n\nconst ENDED: Record = {\n\tcompleted: \"finished\",\n\tskipped: \"finished\",\n\tfailed: \"failed\",\n\tblocked: \"failed\",\n\tkilled: \"stopped\",\n\tcancelled: \"stopped\",\n};\n\n/** Folds one lifecycle event into its root run's card. */\nexport function foldLifecycle(\n\tcards: Map,\n\tevent: WorkflowLifecycleEvent,\n\tname?: string,\n): void {\n\tlet seconds = Math.floor(event.occurredAt / 1000);\n\tlet card = cards.get(event.rootRunId);\n\tif (!card) {\n\t\tcard = {\n\t\t\tid: event.rootRunId,\n\t\t\tname: name ?? \"workflow\",\n\t\t\tstatus: \"running\",\n\t\t\tstarted: seconds,\n\t\t\tupdated: seconds,\n\t\t\tstages: [],\n\t\t\twaiting: 0,\n\t\t\tstageIndex: new Map(),\n\t\t\tprompts: new Set(),\n\t\t};\n\t\tcards.set(event.rootRunId, card);\n\t}\n\tif (name) card.name = name;\n\tcard.updated = Math.max(card.updated, seconds);\n\tlet target = event.target;\n\tif (target.kind === \"run\" && target.runId === event.rootRunId) {\n\t\tcard.status = ENDED[target.status] ?? (target.status === \"paused\" ? \"paused\" : \"running\");\n\t\tif (card.status === \"finished\" || card.status === \"failed\" || card.status === \"stopped\") {\n\t\t\tcard.ended = seconds;\n\t\t} else delete card.ended;\n\t} else if (target.kind === \"stage\") {\n\t\tlet key = `${target.runId}:${target.stageId}`;\n\t\tlet index = card.stageIndex.get(key);\n\t\tif (index === undefined) {\n\t\t\tindex = card.stages.length;\n\t\t\tcard.stageIndex.set(key, index);\n\t\t\tcard.stages.push({ id: key, name: target.stageName, status: target.status });\n\t\t}\n\t\tlet stage = card.stages[index]!;\n\t\tstage.status = target.status;\n\t\tif (target.status === \"running\" && stage.started === undefined) stage.started = seconds;\n\t\tif (\n\t\t\ttarget.status === \"completed\" || target.status === \"failed\" || target.status === \"skipped\"\n\t\t) {\n\t\t\tstage.ended = seconds;\n\t\t}\n\t} else if (target.kind === \"prompt\") {\n\t\tif (target.status === \"opened\") card.prompts.add(target.promptId);\n\t\telse card.prompts.delete(target.promptId);\n\t\tcard.waiting = card.prompts.size;\n\t}\n}\n\n/** The run cards to show, with the live/paused split from activity taking precedence over lifecycle. */\nexport function runCards(cards: Map, runs: Omit): Wire.Run[] {\n\treturn [...cards.values()].map(({ stageIndex: _index, prompts: _prompts, ...card }) => {\n\t\tlet status: Wire.Run[\"status\"] = runs.paused.includes(card.id)\n\t\t\t? \"paused\"\n\t\t\t: runs.active.includes(card.id)\n\t\t\t? card.waiting > 0 ? \"waiting\" : \"running\"\n\t\t\t: card.status === \"running\" || card.status === \"waiting\"\n\t\t\t? \"finished\"\n\t\t\t: card.status;\n\t\treturn { ...card, status, stages: card.stages.map(stage => ({ ...stage })) };\n\t});\n}\n\n/** The workflow run id reported in a `workflow` tool result, when the call started one. */\nfunction launchedRunId(content: readonly { type: string; text?: string }[]): string | undefined {\n\tlet text = content.map(part => part.type === \"text\" ? part.text ?? \"\" : \"\").join(\"\\n\");\n\treturn /\"runId\"\\s*:\\s*\"([0-9a-f-]{36})\"/.exec(text)?.[1];\n}\n\n/**\n * Keeps `planner.runs` in step with the workflows this session owns, through\n * Atomic's public activity stream and lifecycle hooks. Recovering or\n * unavailable snapshots are unknown rather than empty, so they leave the last\n * known runs in place.\n */\nexport function workflowRuns(planner: FullPlanner): ExtensionFactory {\n\treturn (atomic: ExtensionAPI): void => {\n\t\tlet lease: WorkflowActivitySubscription | undefined;\n\t\tlet roots = new Map();\n\t\tlet cards = new Map();\n\t\tlet names = new Map();\n\t\tlet ready = false;\n\t\tlet publish = () => {\n\t\t\tif (!ready) return;\n\t\t\tlet split = classifyRuns(roots.values());\n\t\t\tfor (let id of cards.keys()) {\n\t\t\t\tif (!split.active.includes(id) && !split.paused.includes(id) && !roots.has(id)) {\n\t\t\t\t\tlet card = cards.get(id)!;\n\t\t\t\t\tif (card.status === \"running\" || card.status === \"waiting\") card.status = \"finished\";\n\t\t\t\t}\n\t\t\t}\n\t\t\tplanner.runs = { ...split, cards: runCards(cards, split) };\n\t\t\tplanner.onRuns?.(planner.runs);\n\t\t};\n\t\tatomic.on(\"session_start\", (_event, ctx) => {\n\t\t\tlease?.dispose();\n\t\t\tlease = ctx.observeWorkflowActivity(frame => {\n\t\t\t\tif (frame.kind === \"snapshot\") {\n\t\t\t\t\tif (frame.availability !== \"ready\") return;\n\t\t\t\t\tready = true;\n\t\t\t\t\troots = new Map(frame.roots.map(root => [root.rootRunId, root]));\n\t\t\t\t} else if (frame.kind === \"changed\") roots.set(frame.root.rootRunId, frame.root);\n\t\t\t\telse roots.delete(frame.rootRunId);\n\t\t\t\tpublish();\n\t\t\t});\n\t\t});\n\t\tatomic.on(\"tool_result\", event => {\n\t\t\tif (event.toolName !== \"workflow\" || event.input.action !== \"run\") return;\n\t\t\tlet runId = launchedRunId(event.content);\n\t\t\tlet name = typeof event.input.workflow === \"string\" ? event.input.workflow : undefined;\n\t\t\tif (!runId || !name) return;\n\t\t\tnames.set(runId, name);\n\t\t\tlet card = cards.get(runId);\n\t\t\tif (card) {\n\t\t\t\tcard.name = name;\n\t\t\t\tpublish();\n\t\t\t}\n\t\t});\n\t\tatomic.on(\"workflow_lifecycle\", event => {\n\t\t\tfoldLifecycle(cards, event, names.get(event.rootRunId));\n\t\t\tpublish();\n\t\t});\n\t\tatomic.on(\"session_shutdown\", () => lease?.dispose());\n\t};\n}\n","editable",false,"branch","documentNavigation","repo","githubnext/chopin","repoId","7d1a8ac3-35b0-4dea-85d4-06a980f3bada","ownerId","org:89615882","site","nexthub","private","admin","settings","maintainer","triage","starred","stars",0,"watchers","watching","pinned","notify","views",[183,184,185,186,187,188,189,190,191,192,193,194,195],"navigation",{"_54":55,"_139":140,"_141":142,"_143":144,"_145":146,"_147":148,"_149":150},"sources",[],"viewer","meta",{"_131":132,"_133":134,"_135":136,"_42":31,"_137":126,"_138":31,"_48":49,"_50":49},"branches",[73,74,75,76,77,78,79,80,81,82,83,84,85,86,87,88,89,90,91,92,93,94,95,96,97,98,99,100,101,102,103,104,105,106,107,108,109,110,111,112,113,114,115,116,117,118,119,120,121,122,123,124,125,126,127,128,129,130],"tags",[69,70,71,72],"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",[165,166,167],"documents",{"_160":161,"_162":163},"code",{"_156":157,"_158":159},"automations",{"_153":154,"_155":-5},"delivery",{"_151":49,"_152":-5},"tag","04zvKQ8QOrDUF8TO1Ovz0Zy8_TT","releases","applications","workflows",3,"deployments","commits",1000,"changes",13,"counts",{"_164":163},"total",11,"issue",{"_168":158,"_170":181,"_15":158,"_172":182,"_52":174,"_175":31,"_176":174,"_177":159},{"_168":178,"_170":179,"_15":178,"_172":180,"_52":174,"_175":31,"_176":174,"_177":49},{"_168":169,"_170":171,"_15":169,"_172":173,"_52":174,"_175":31,"_176":174,"_177":163},"id","issues","name","Issues","filters",{},true,"saved","pinnable","count","tasks","Tasks",{},"Changes",{},{"_168":158,"_170":181,"_15":158,"_172":226,"_52":174,"_175":31,"_176":174},{"_168":178,"_170":179,"_15":178,"_172":225,"_52":174,"_175":31,"_176":174},{"_168":169,"_170":171,"_15":169,"_172":224,"_52":174,"_175":31,"_176":174},{"_168":221,"_170":222,"_15":221,"_172":223,"_52":31,"_175":31,"_176":174},{"_168":218,"_170":219,"_15":218,"_172":220,"_52":31,"_175":31,"_176":174},{"_168":153,"_170":216,"_15":145,"_172":217,"_52":31,"_175":31,"_176":174},{"_168":155,"_170":213,"_15":214,"_172":215,"_52":31,"_175":31,"_176":174},{"_168":151,"_170":211,"_15":151,"_172":212,"_52":31,"_175":31,"_176":174},{"_168":207,"_170":208,"_15":209,"_172":210,"_52":31,"_175":31,"_176":174},{"_168":141,"_170":205,"_15":141,"_172":206,"_52":31,"_175":31,"_176":31},{"_168":202,"_170":203,"_15":202,"_172":204,"_52":31,"_175":31,"_176":31},{"_168":199,"_170":200,"_15":199,"_172":201,"_52":31,"_175":31,"_176":31},{"_168":196,"_170":197,"_15":196,"_172":198,"_52":31,"_175":31,"_176":31},"decisions","Decisions",{},"changelog","Changelog",{},"roadmap","Roadmap",{},"Documents",{},"activity","Activity","insights",{},"Releases",{},"Deployments","automations/deployments",{},"Workflows",{},"discussions","Discussions",{},"goals","Goals",{},{},{},{},"groups","user","agents",[],"now",1794475102713,"sidebar","expanded"]