[{"_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",{"_41":42,"_227":-5,"_228":-5,"_229":230},"routes/repo",{"_34":-7,"_35":36,"_37":38,"_39":40,"_41":42,"_43":32,"_44":32,"_45":32,"_46":32,"_47":32,"_48":32,"_49":50,"_51":50,"_52":32,"_53":-7,"_54":-7,"_55":56,"_57":58,"_59":60,"_61":-5,"_62":63,"_64":65,"_66":67,"_68":69},"routes/repo.blob",{"_13":14,"_15":16,"_17":18,"_19":20,"_21":22,"_23":24,"_25":-5,"_26":27,"_28":29,"_29":30,"_31":32,"_33":14},"ref","main","path","apps/server/src/harness/atomic/adapter.ts","oid","a23021baa2316158e8a108c1692d01bb2234c5e9","size",27328,"commit","2182c95de44a8f63fd86af1c5874ae0ca298f807","mounts",[],"source","plain",{"_13":14,"_15":16},"kind","text","/**\n * Chopin's Atomic `HarnessV1` adapter.\n *\n * A Planner session that Chopin registers by session ID runs as a full Atomic\n * session: Atomic builtins, the operator's Atomic resources, a channel working\n * directory, and Chopin as HostInput. Its own turns only offer the tools in\n * `FULL_PLANNER_TOOLS` beside Chopin's; the workflows it starts keep their\n * stages' tools. Every other session (the summary and research workers) stays\n * isolated: only Chopin host tools, no host resources, and a checked per-turn\n * tool boundary.\n */\n\nimport { HarnessCapabilityUnsupportedError } from \"@ai-sdk/harness\";\nimport {\n\tAuthStorage,\n\tcreateAgentSession,\n\tDefaultResourceLoader,\n\tFileAuthStorageBackend,\n\tgetAgentConfigPaths,\n\tgetAgentDir,\n\tModelRuntime,\n\tSessionManager,\n\tSettingsManager,\n} from \"@bastani/atomic\";\nimport { mkdtemp, readFile, rm } from \"node:fs/promises\";\nimport { tmpdir } from \"node:os\";\nimport { join } from \"node:path\";\nimport { fullPlanner, workflowRuns } from \"./full\";\n\nimport type {\n\tHarnessV1,\n\tHarnessV1PromptControl,\n\tHarnessV1PromptTurnOptions,\n\tHarnessV1ResponseFormat,\n\tHarnessV1ResumeSessionState,\n\tHarnessV1Session,\n\tHarnessV1StartOptions,\n\tHarnessV1StreamPart,\n\tHarnessV1ToolSpec,\n} from \"@ai-sdk/harness\";\nimport type {\n\tAgentSession,\n\tAgentSessionEvent,\n\tExtensionAPI,\n\tExtensionFactory,\n\tToolDefinition,\n} from \"@bastani/atomic\";\n\nexport const ATOMIC_AUTH_MODES = [\"auto\", \"ai-gateway\"] as const;\n\nexport type AtomicAuthMode = (typeof ATOMIC_AUTH_MODES)[number];\n\nexport const ATOMIC_RESULT_TOOL_NAME = \"chopin_submit_atomic_result\";\n\nexport const ATOMIC_RESULT_INSTRUCTION =\n\t`When you have the final answer for this turn, call the ${ATOMIC_RESULT_TOOL_NAME} tool exactly `\n\t+ \"once with the required fields instead of replying in plain text.\";\n\n/** Replaces Atomic's coding-agent preamble on turns that bring no instructions. */\nexport const ATOMIC_DEFAULT_SYSTEM_PROMPT =\n\t\"Respond to the user's message. Use only the tools this turn provides.\";\n\n/**\n * What a full Planner's own turns may call besides Chopin's tools: reading the\n * checkout and the web, asking Decisions, running workflows, and Intercom. It\n * cannot edit files or run commands, so implementing the plan goes to another\n * session.\n */\nexport const FULL_PLANNER_TOOLS: ReadonlySet = new Set([\n\t\"read\",\n\t\"find\",\n\t\"search\",\n\t\"ast_grep\",\n\t\"web_search\",\n\t\"code_search\",\n\t\"fetch_content\",\n\t\"get_search_content\",\n\t\"ask_user_question\",\n\t\"workflow\",\n\t\"intercom\",\n]);\n\nconst GATEWAY_PROVIDER = \"vercel-ai-gateway\";\nconst OPERATION_TIMEOUT_MS = 10_000;\nconst BUILTINS_OFF = {\n\tworkflows: false,\n\tsubagents: false,\n\tmcp: false,\n\t\"web-access\": false,\n\tintercom: false,\n};\nconst SETTINGS = {\n\tcompaction: { enabled: false },\n\tsessionSummary: { enabled: false },\n\tcacheWarming: \"off\" as const,\n};\n\nasync function optionalFile(path: string): Promise {\n\treturn readFile(path, \"utf8\").catch(error => {\n\t\tif (error.code === \"ENOENT\") return undefined;\n\t\tthrow error;\n\t});\n}\n\n/**\n * The operator's settings plus the working directory's project settings, held in\n * memory so the session never writes either file. A verified checkout's\n * `.atomic/settings.json` can add project packages the way it does for a local\n * Atomic session; the empty per-channel directory has none.\n */\nasync function fullSettings(agentDir: string, cwd: string): Promise {\n\tlet scopes: Record<\"global\" | \"project\", string | undefined> = {\n\t\tglobal: JSON.stringify({\n\t\t\t...JSON.parse(await optionalFile(join(agentDir, \"settings.json\")) ?? \"{}\"),\n\t\t\t...SETTINGS,\n\t\t}),\n\t\tproject: await optionalFile(join(cwd, \".atomic\", \"settings.json\")),\n\t};\n\tlet manager = SettingsManager.fromStorage({\n\t\twithLock(scope, fn) {\n\t\t\tlet next = fn(scopes[scope]);\n\t\t\tif (next !== undefined) scopes[scope] = next;\n\t\t},\n\t}, { projectTrusted: true });\n\tmanager.applyOverrides(SETTINGS);\n\treturn manager;\n}\nconst ZERO_USAGE = {\n\tinputTokens: {\n\t\ttotal: undefined,\n\t\tnoCache: undefined,\n\t\tcacheRead: undefined,\n\t\tcacheWrite: undefined,\n\t},\n\toutputTokens: { total: undefined, text: undefined, reasoning: undefined },\n};\n\ntype ProviderConfig = Parameters[1];\ntype Model = NonNullable>;\ntype ToolOutcome = { output: unknown; isError?: boolean };\n\nexport type AtomicSettings = {\n\tauth: AtomicAuthMode;\n\t/** Model, as `provider/model`, for turns that name none. */\n\tmodel?: string;\n\t/** Providers registered by code rather than discovered from the host. */\n\tproviders?: Record;\n\t/**\n\t * Extension or package paths every Planner session loads, as the CLI's\n\t * `--extension` would; their workflows and skills register too. Worker\n\t * sessions never load them.\n\t */\n\textensions?: readonly string[];\n};\n\nexport class ToolBoundaryError extends Error {\n\tconstructor(message: string) {\n\t\tsuper(message);\n\t\tthis.name = \"ToolBoundaryError\";\n\t}\n}\n\n/** What the turn extension enforces; the adapter rewrites it before each turn. */\nexport type TurnPolicy = {\n\thostNames: string[];\n\tstructured: boolean;\n\tsystemPrompt: string;\n\tresult?: { value: unknown };\n\tfull?: boolean;\n};\n\n/**\n * Registers the terminating result tool and applies the per-turn policy: the\n * active tools and the exact system prompt. `structured` comes only from the\n * turn's response format, never from prompt text, so quoted chat cannot switch\n * the result tool on.\n */\nexport function atomicTurnExtension(policy: TurnPolicy): ExtensionFactory {\n\treturn (atomic: ExtensionAPI): void => {\n\t\tatomic.registerTool({\n\t\t\tname: ATOMIC_RESULT_TOOL_NAME,\n\t\t\tlabel: \"Submit result\",\n\t\t\tdescription: \"Submit the final structured result for this turn.\",\n\t\t\tparameters: { type: \"object\", additionalProperties: true } as ToolDefinition[\"parameters\"],\n\t\t\tmaxResultSizeChars: Infinity,\n\t\t\tasync execute(_toolCallId, params) {\n\t\t\t\tpolicy.result = { value: params };\n\t\t\t\treturn {\n\t\t\t\t\tcontent: [{ type: \"text\", text: \"Result received.\" }],\n\t\t\t\t\tdetails: params,\n\t\t\t\t\tterminate: true,\n\t\t\t\t};\n\t\t\t},\n\t\t});\n\t\tatomic.on(\"before_agent_start\", event => {\n\t\t\tif (!policy.full) atomic.setActiveTools(activeNames(policy));\n\t\t\treturn {\n\t\t\t\tsystemPrompt: policy.full\n\t\t\t\t\t? `${event.systemPrompt}\\n\\n${policy.systemPrompt}`\n\t\t\t\t\t: policy.systemPrompt,\n\t\t\t};\n\t\t});\n\t\tatomic.on(\"tool_call\", event => {\n\t\t\tif (policy.full && event.toolName !== ATOMIC_RESULT_TOOL_NAME) return;\n\t\t\tif (activeNames(policy).includes(event.toolName)) return;\n\t\t\treturn { block: true, reason: `${event.toolName} is not available in this turn.` };\n\t\t});\n\t};\n}\n\nfunction activeNames(policy: TurnPolicy): string[] {\n\treturn policy.structured ? [...policy.hostNames, ATOMIC_RESULT_TOOL_NAME] : [...policy.hostNames];\n}\n\nexport function turnSystemPrompt(\n\tinstructions: string | undefined,\n\tresponseFormat: HarnessV1ResponseFormat | undefined,\n): string {\n\tlet result = responseFormat?.type === \"json\"\n\t\t? [\n\t\t\tATOMIC_RESULT_INSTRUCTION,\n\t\t\tresponseFormat.description,\n\t\t\t`The ${ATOMIC_RESULT_TOOL_NAME} arguments must match this JSON schema: ${\n\t\t\t\tJSON.stringify(responseFormat.schema ?? { type: \"object\" })\n\t\t\t}`,\n\t\t].filter(Boolean).join(\"\\n\")\n\t\t: undefined;\n\treturn [instructions, result].filter(Boolean).join(\"\\n\\n\") || ATOMIC_DEFAULT_SYSTEM_PROMPT;\n}\n\n/** Looks up `provider/model` without letting Atomic substitute a default. */\nexport function resolveModel(\n\truntime: Pick,\n\tsettings: Pick,\n\trequested: string | undefined,\n): Model {\n\tif (!requested) throw new Error(\"Atomic needs a model named as provider/model.\");\n\tlet slash = requested.indexOf(\"/\");\n\tlet provider = requested.slice(0, slash);\n\tlet model = slash > 0 ? runtime.getModel(provider, requested.slice(slash + 1)) : undefined;\n\tif (!model) throw new Error(`Atomic does not recognize model ${requested}`);\n\tif (\n\t\tsettings.auth === \"ai-gateway\" && provider !== GATEWAY_PROVIDER\n\t\t&& !Object.hasOwn(settings.providers ?? {}, provider)\n\t) {\n\t\tthrow new Error(\n\t\t\t`HARNESS_AUTH ai-gateway allows only ${GATEWAY_PROVIDER} models, not ${requested}`,\n\t\t);\n\t}\n\treturn model;\n}\n\n/**\n * Credentials live only in memory. `auto` copies the host's Atomic login once,\n * read without a lock file, so a token refresh can never be written back.\n */\nasync function createRuntime(settings: AtomicSettings): Promise {\n\tlet login = {};\n\tif (settings.auth === \"auto\") {\n\t\tlet paths = getAgentConfigPaths(\"auth.json\");\n\t\tlet content = new FileAuthStorageBackend(paths[0], paths).read();\n\t\tif (content) login = JSON.parse(content);\n\t}\n\tlet runtime = await ModelRuntime.create({\n\t\tcredentials: AuthStorage.inMemory(login),\n\t\tmodelsPath: null,\n\t\tallowModelNetwork: false,\n\t});\n\tfor (let [id, config] of Object.entries(settings.providers ?? {})) {\n\t\truntime.registerProvider(id, config);\n\t}\n\treturn runtime;\n}\n\nfunction unsupported(capability: string): HarnessCapabilityUnsupportedError {\n\treturn new HarnessCapabilityUnsupportedError({\n\t\tharnessId: \"atomic\",\n\t\tmessage: `Atomic adapter does not support ${capability}.`,\n\t});\n}\n\nfunction bounded(operation: Promise, message: string): Promise {\n\tlet timer: ReturnType | undefined;\n\treturn Promise.race([\n\t\toperation,\n\t\tnew Promise((_, reject) => {\n\t\t\ttimer = setTimeout(() => reject(new Error(message)), OPERATION_TIMEOUT_MS);\n\t\t}),\n\t]).finally(() => clearTimeout(timer));\n}\n\nfunction promptText(prompt: HarnessV1PromptTurnOptions[\"prompt\"]): string {\n\tif (typeof prompt === \"string\") return prompt;\n\tif (typeof prompt.content === \"string\") return prompt.content;\n\treturn prompt.content.map(part => {\n\t\tif (part.type !== \"text\") throw unsupported(`${part.type} prompt parts`);\n\t\treturn part.text;\n\t}).join(\"\\n\\n\");\n}\n\nfunction sameNames(actual: readonly string[], expected: readonly string[]): boolean {\n\tlet left = [...actual].sort();\n\tlet right = [...expected].sort();\n\treturn left.length === right.length && left.every((name, index) => name === right[index]);\n}\n\n/** What a freshly built session exposes beyond the turn extension and the host tools, if anything. */\nexport function hostLeak(\n\tsession: Pick,\n\textensions: number,\n\thostNames: readonly string[],\n): string | undefined {\n\tlet resources = session.resourceLoader;\n\tlet tools = session.getAllTools().map(tool => tool.name);\n\tlet found = [\n\t\textensions !== 1 && `${extensions} extensions`,\n\t\t!sameNames(tools, [...hostNames, ATOMIC_RESULT_TOOL_NAME]) && `tools ${tools.join(\", \")}`,\n\t\tresources.getAgentsFiles().agentsFiles.length > 0 && \"context files\",\n\t\tresources.getSkills().skills.length > 0 && \"skills\",\n\t\tresources.getPrompts().prompts.length > 0 && \"prompt templates\",\n\t\tresources.getAppendSystemPrompt().length > 0 && \"appended system prompts\",\n\t\tresources.getSystemPrompt() !== ATOMIC_DEFAULT_SYSTEM_PROMPT && \"a host system prompt\",\n\t].filter(Boolean);\n\treturn found.length > 0 ? found.join(\"; \") : undefined;\n}\n\nfunction serialize(output: unknown): string {\n\treturn typeof output === \"string\" ? output : JSON.stringify(output ?? null);\n}\n\n/** Atomic's tool result as one string: its text content when it has any, else its JSON. */\nexport function resultText(result: unknown): string {\n\tlet content = (result as { content?: unknown } | null)?.content;\n\tif (Array.isArray(content)) {\n\t\tlet text = content.flatMap(part => part?.type === \"text\" ? [String(part.text)] : []);\n\t\tif (text.length > 0) return text.join(\"\\n\");\n\t}\n\treturn serialize(result);\n}\n\n/**\n * The stream parts for a tool Atomic runs itself: a builtin, extension, workflow\n * or subagent tool. Host tools report through `hostTool`, and a nested call\n * belongs to its parent's row.\n */\nexport function ownToolParts(\n\tevent: AgentSessionEvent,\n\thostNames: readonly string[],\n): HarnessV1StreamPart[] {\n\tif (\n\t\tevent.type !== \"tool_execution_start\" && event.type !== \"tool_execution_update\"\n\t\t&& event.type !== \"tool_execution_end\"\n\t) return [];\n\tif (\n\t\tevent.parentToolCallId || hostNames.includes(event.toolName)\n\t\t|| event.toolName === ATOMIC_RESULT_TOOL_NAME\n\t) return [];\n\tlet own = { toolCallId: event.toolCallId, toolName: event.toolName };\n\tif (event.type === \"tool_execution_start\") {\n\t\treturn [{\n\t\t\ttype: \"tool-call\",\n\t\t\t...own,\n\t\t\tinput: JSON.stringify(event.args ?? {}),\n\t\t\tproviderExecuted: true,\n\t\t\tdynamic: true,\n\t\t}];\n\t}\n\treturn [{\n\t\ttype: \"tool-result\",\n\t\t...own,\n\t\tresult: resultText(event.type === \"tool_execution_end\" ? event.result : event.partialResult),\n\t\t...(event.type === \"tool_execution_end\"\n\t\t\t? { isError: event.isError }\n\t\t\t: { preliminary: true }),\n\t\tdynamic: true,\n\t}];\n}\n\n/**\n * The streaming input of a tool call: its row can open before its arguments\n * finish. An isolated session streams only its host tools, so a hallucinated\n * tool stays out of the stream.\n */\nexport function inputParts(\n\tupdate: Extract[\"assistantMessageEvent\"],\n\tinputs: Map,\n\thostNames: readonly string[],\n\tfull: boolean,\n): HarnessV1StreamPart[] {\n\tif (!update.type.startsWith(\"toolcall_\") || !(\"contentIndex\" in update)) return [];\n\tlet id = inputs.get(update.contentIndex);\n\tif (update.type === \"toolcall_start\") {\n\t\tlet call = update.partial.content[update.contentIndex];\n\t\tif (call?.type !== \"toolCall\" || !full && !hostNames.includes(call.name)) return [];\n\t\tinputs.set(update.contentIndex, call.id);\n\t\treturn [{\n\t\t\ttype: \"tool-input-start\",\n\t\t\tid: call.id,\n\t\t\ttoolName: call.name,\n\t\t\t...(hostNames.includes(call.name) ? {} : { providerExecuted: true, dynamic: true }),\n\t\t}];\n\t}\n\tif (!id) return [];\n\tif (update.type === \"toolcall_delta\") {\n\t\treturn [{ type: \"tool-input-delta\", id, delta: update.delta }];\n\t}\n\tinputs.delete(update.contentIndex);\n\treturn [{ type: \"tool-input-end\", id }];\n}\n\ntype Run = {\n\temit: (part: HarnessV1StreamPart) => void;\n\tpending: Map void>;\n\tblocks: Map;\n\tinputs: Map;\n\tstopped: boolean;\n\tfailure?: Error;\n\tlast?: { stopReason: string; errorMessage?: string };\n\tstop: () => void;\n\tdone: Promise;\n};\n\nfunction control(run: Run): HarnessV1PromptControl {\n\treturn {\n\t\tasync submitToolResult({ toolCallId, output, isError }) {\n\t\t\trun.pending.get(toolCallId)?.({ output, isError });\n\t\t},\n\t\tasync submitToolApproval() {\n\t\t\t// The adapter emits no approval requests; there is nothing to answer.\n\t\t},\n\t\tdone: run.done,\n\t};\n}\n\nfunction listen(run: Run, signal: AbortSignal | undefined): void {\n\tif (!signal) return;\n\tif (signal.aborted) run.stop();\n\telse signal.addEventListener(\"abort\", run.stop, { once: true });\n\tvoid run.done.catch(() => {}).finally(() => signal.removeEventListener(\"abort\", run.stop));\n}\n\n/** Host-process `HarnessV1` implementation over `@bastani/atomic`. */\nexport function createAtomicAdapter(\n\tsettings: AtomicSettings,\n): HarnessV1 & { shutdown(): Promise } {\n\tif (!ATOMIC_AUTH_MODES.includes(settings.auth)) {\n\t\tthrow new Error(`HARNESS_AUTH ${settings.auth} is not a supported atomic authentication mode`);\n\t}\n\tlet runtime: Promise | undefined;\n\tlet open = new Set();\n\n\treturn {\n\t\tspecificationVersion: \"harness-v1\",\n\t\tharnessId: \"atomic\",\n\t\tbuiltinTools: {},\n\t\tsupportsBuiltinToolFiltering: true,\n\n\t\tasync doStart(startOptions: HarnessV1StartOptions): Promise {\n\t\t\tif (startOptions.resumeFrom || startOptions.continueFrom) {\n\t\t\t\tthrow unsupported(\"resuming an in-memory session\");\n\t\t\t}\n\t\t\tlet directory: string | undefined;\n\t\t\tlet full = fullPlanner(startOptions.sessionId);\n\t\t\tlet sessionManager: SessionManager | undefined;\n\t\t\tlet settingsManager = SettingsManager.inMemory(SETTINGS);\n\t\t\tlet policy: TurnPolicy = {\n\t\t\t\tfull: !!full,\n\t\t\t\thostNames: [],\n\t\t\t\tstructured: false,\n\t\t\t\tsystemPrompt: ATOMIC_DEFAULT_SYSTEM_PROMPT,\n\t\t\t};\n\t\t\tlet live: { session: AgentSession; signature: string; release: () => void } | undefined;\n\t\t\tlet current: Run | undefined;\n\t\t\tlet closed: Promise | undefined;\n\n\t\t\tfunction hostTool(spec: HarnessV1ToolSpec): ToolDefinition {\n\t\t\t\treturn {\n\t\t\t\t\tname: spec.name,\n\t\t\t\t\tlabel: spec.name,\n\t\t\t\t\tdescription: spec.description ?? \"\",\n\t\t\t\t\tparameters: (spec.inputSchema ?? { type: \"object\" }) as ToolDefinition[\"parameters\"],\n\t\t\t\t\tmaxResultSizeChars: Infinity,\n\t\t\t\t\tasync execute(toolCallId, params, signal) {\n\t\t\t\t\t\tlet run = current;\n\t\t\t\t\t\tif (!run || run.stopped || signal?.aborted) throw new Error(\"The turn was aborted.\");\n\t\t\t\t\t\tlet settled = Promise.withResolvers();\n\t\t\t\t\t\tlet abort = () => settled.resolve({ output: \"The turn was aborted.\", isError: true });\n\t\t\t\t\t\trun.pending.set(toolCallId, settled.resolve);\n\t\t\t\t\t\tsignal?.addEventListener(\"abort\", abort, { once: true });\n\t\t\t\t\t\trun.emit({\n\t\t\t\t\t\t\ttype: \"tool-call\",\n\t\t\t\t\t\t\ttoolCallId,\n\t\t\t\t\t\t\ttoolName: spec.name,\n\t\t\t\t\t\t\tinput: JSON.stringify(params ?? {}),\n\t\t\t\t\t\t});\n\t\t\t\t\t\tlet outcome = await settled.promise;\n\t\t\t\t\t\tsignal?.removeEventListener(\"abort\", abort);\n\t\t\t\t\t\trun.pending.delete(toolCallId);\n\t\t\t\t\t\tif (run.stopped || signal?.aborted) throw new Error(\"The turn was aborted.\");\n\t\t\t\t\t\trun.emit({\n\t\t\t\t\t\t\ttype: \"tool-result\",\n\t\t\t\t\t\t\ttoolCallId,\n\t\t\t\t\t\t\ttoolName: spec.name,\n\t\t\t\t\t\t\tresult: (outcome.output ?? null) as NonNullable,\n\t\t\t\t\t\t\tisError: outcome.isError,\n\t\t\t\t\t\t});\n\t\t\t\t\t\tif (outcome.isError) throw new Error(serialize(outcome.output));\n\t\t\t\t\t\treturn { content: [{ type: \"text\", text: serialize(outcome.output) }], details: {} };\n\t\t\t\t\t},\n\t\t\t\t};\n\t\t\t}\n\n\t\t\tfunction observe(session: AgentSession, event: AgentSessionEvent): void {\n\t\t\t\tlet run = current;\n\t\t\t\tif (!run) return;\n\t\t\t\tif (event.type === \"turn_start\") {\n\t\t\t\t\tlet offered = session.agent.state.tools.map(tool => tool.name);\n\t\t\t\t\tif (!full && !sameNames(offered, activeNames(policy))) {\n\t\t\t\t\t\trun.failure ??= new ToolBoundaryError(\n\t\t\t\t\t\t\t`Atomic offered unexpected tools: ${offered.join(\", \") || \"none\"}.`,\n\t\t\t\t\t\t);\n\t\t\t\t\t\trun.stop();\n\t\t\t\t\t}\n\t\t\t\t\tif (run.stopped) session.agent.abort();\n\t\t\t\t\treturn;\n\t\t\t\t}\n\t\t\t\tif (full) {\n\t\t\t\t\tfor (let part of ownToolParts(event, policy.hostNames)) {\n\t\t\t\t\t\tif (part.type === \"tool-result\") {\n\t\t\t\t\t\t\tfull.toolReport?.(\n\t\t\t\t\t\t\t\tpart.toolCallId,\n\t\t\t\t\t\t\t\tpart.result,\n\t\t\t\t\t\t\t\tpart.preliminary ? \"running\" : part.isError ? \"failed\" : \"done\",\n\t\t\t\t\t\t\t);\n\t\t\t\t\t\t}\n\t\t\t\t\t\trun.emit(part);\n\t\t\t\t\t}\n\t\t\t\t}\n\t\t\t\tif (!(\"message\" in event) || event.message.role !== \"assistant\") return;\n\t\t\t\tif (event.type === \"message_start\") {\n\t\t\t\t\trun.blocks.clear();\n\t\t\t\t\trun.inputs.clear();\n\t\t\t\t} else if (event.type === \"message_end\") {\n\t\t\t\t\tfor (let block of run.blocks.values()) {\n\t\t\t\t\t\trun.emit({ type: `${block.kind}-end`, id: block.id });\n\t\t\t\t\t}\n\t\t\t\t\trun.blocks.clear();\n\t\t\t\t\trun.last = event.message;\n\t\t\t\t} else if (event.type === \"message_update\" && !policy.structured) {\n\t\t\t\t\tlet update = event.assistantMessageEvent;\n\t\t\t\t\tfor (let part of inputParts(update, run.inputs, policy.hostNames, !!full)) run.emit(part);\n\t\t\t\t\tlet kind = update.type.startsWith(\"text_\")\n\t\t\t\t\t\t? \"text\" as const\n\t\t\t\t\t\t: update.type.startsWith(\"thinking_\")\n\t\t\t\t\t\t? \"reasoning\" as const\n\t\t\t\t\t\t: undefined;\n\t\t\t\t\tif (!kind || !(\"contentIndex\" in update)) return;\n\t\t\t\t\tlet block = run.blocks.get(update.contentIndex);\n\t\t\t\t\tif (!block) {\n\t\t\t\t\t\tblock = { id: crypto.randomUUID(), kind };\n\t\t\t\t\t\trun.blocks.set(update.contentIndex, block);\n\t\t\t\t\t\trun.emit({ type: `${kind}-start`, id: block.id });\n\t\t\t\t\t}\n\t\t\t\t\tif (update.type === \"text_delta\" || update.type === \"thinking_delta\") {\n\t\t\t\t\t\trun.emit({ type: `${kind}-delta`, id: block.id, delta: update.delta });\n\t\t\t\t\t} else if (update.type === \"text_end\" || update.type === \"thinking_end\") {\n\t\t\t\t\t\trun.emit({ type: `${kind}-end`, id: block.id });\n\t\t\t\t\t\trun.blocks.delete(update.contentIndex);\n\t\t\t\t\t}\n\t\t\t\t}\n\t\t\t}\n\n\t\t\tasync function prepare(turn: HarnessV1PromptTurnOptions): Promise {\n\t\t\t\tif (turn.skills.length > 0) throw unsupported(\"skills\");\n\t\t\t\tlet hostNames = turn.tools.map(spec => spec.name);\n\t\t\t\tif (hostNames.includes(ATOMIC_RESULT_TOOL_NAME)) {\n\t\t\t\t\tthrow new Error(\n\t\t\t\t\t\t`Host tool name ${ATOMIC_RESULT_TOOL_NAME} is reserved for structured output.`,\n\t\t\t\t\t);\n\t\t\t\t}\n\t\t\t\tlet models = await (runtime ??= createRuntime(settings));\n\t\t\t\tlet model = resolveModel(models, settings, turn.model ?? settings.model);\n\t\t\t\tlet signature = JSON.stringify(turn.tools);\n\t\t\t\tif (live && live.signature !== signature) {\n\t\t\t\t\tlive.release();\n\t\t\t\t\tawait live.session.dispose();\n\t\t\t\t\tlive = undefined;\n\t\t\t\t}\n\t\t\t\tpolicy.hostNames = hostNames;\n\t\t\t\tpolicy.structured = false;\n\t\t\t\tif (!live) {\n\t\t\t\t\tif (!full) directory ??= await mkdtemp(join(tmpdir(), \"chopin-atomic-planner-\"));\n\t\t\t\t\tlet cwd = full?.cwd ?? directory!;\n\t\t\t\t\tlet agentDir = full ? getAgentDir() : directory!;\n\t\t\t\t\tif (full) settingsManager = await fullSettings(agentDir, cwd);\n\t\t\t\t\tsessionManager ??= SessionManager.inMemory(cwd);\n\t\t\t\t\tlet loader = new DefaultResourceLoader({\n\t\t\t\t\t\tcwd,\n\t\t\t\t\t\tagentDir,\n\t\t\t\t\t\tsettingsManager,\n\t\t\t\t\t\t...(full ? { additionalExtensionPaths: [...settings.extensions ?? []] } : {\n\t\t\t\t\t\t\tnoExtensions: true,\n\t\t\t\t\t\t\tnoSkills: true,\n\t\t\t\t\t\t\tnoPromptTemplates: true,\n\t\t\t\t\t\t\tnoThemes: true,\n\t\t\t\t\t\t\tnoContextFiles: true,\n\t\t\t\t\t\t\tsystemPrompt: ATOMIC_DEFAULT_SYSTEM_PROMPT,\n\t\t\t\t\t\t\tappendSystemPrompt: [],\n\t\t\t\t\t\t}),\n\t\t\t\t\t\textensionFactories: [\n\t\t\t\t\t\t\tatomicTurnExtension(policy),\n\t\t\t\t\t\t\t...(full ? [workflowRuns(full)] : []),\n\t\t\t\t\t\t],\n\t\t\t\t\t});\n\t\t\t\t\tawait loader.reload();\n\t\t\t\t\tlet created = await createAgentSession({\n\t\t\t\t\t\tcwd,\n\t\t\t\t\t\tagentDir,\n\t\t\t\t\t\tmodelRuntime: models,\n\t\t\t\t\t\tmodel,\n\t\t\t\t\t\tfallbackModels: [],\n\t\t\t\t\t\tsessionManager,\n\t\t\t\t\t\tsettingsManager,\n\t\t\t\t\t\tresourceLoader: loader,\n\t\t\t\t\t\tbuiltins: full ? undefined : BUILTINS_OFF,\n\t\t\t\t\t\ttools: full ? undefined : [...hostNames, ATOMIC_RESULT_TOOL_NAME],\n\t\t\t\t\t\textensionBindings: full ? { humanInput: full.humanInput } : undefined,\n\t\t\t\t\t\tcustomTools: turn.tools.map(hostTool),\n\t\t\t\t\t});\n\t\t\t\t\tlet session = created.session;\n\t\t\t\t\tif (full) {\n\t\t\t\t\t\tfull.workflows = session.workflows;\n\t\t\t\t\t}\n\t\t\t\t\tlet leak = full\n\t\t\t\t\t\t? undefined\n\t\t\t\t\t\t: hostLeak(session, created.extensionsResult.extensions.length, hostNames);\n\t\t\t\t\tif (leak || closed) {\n\t\t\t\t\t\ttry {\n\t\t\t\t\t\t\tawait session.dispose();\n\t\t\t\t\t\t} finally {\n\t\t\t\t\t\t\t// Closing during setup ran cleanup before this directory existed.\n\t\t\t\t\t\t\tif (closed && directory) {\n\t\t\t\t\t\t\t\tawait rm(directory, { recursive: true, force: true });\n\t\t\t\t\t\t\t\tdirectory = undefined;\n\t\t\t\t\t\t\t}\n\t\t\t\t\t\t}\n\t\t\t\t\t\tthrow leak\n\t\t\t\t\t\t\t? new ToolBoundaryError(`Atomic session is not isolated: ${leak}.`)\n\t\t\t\t\t\t\t: new Error(\"Atomic session is closed.\");\n\t\t\t\t\t}\n\t\t\t\t\tlet registered = session.getAllTools().map(tool => tool.name);\n\t\t\t\t\tconsole.log(`[agent] ${registered.length} tools: ${registered.sort().join(\", \")}`);\n\t\t\t\t\tlive = {\n\t\t\t\t\t\tsession,\n\t\t\t\t\t\tsignature,\n\t\t\t\t\t\trelease: session.subscribe(event => observe(session, event)),\n\t\t\t\t\t};\n\t\t\t\t} else if (\n\t\t\t\t\tlive.session.model?.provider !== model.provider || live.session.model.id !== model.id\n\t\t\t\t) {\n\t\t\t\t\tawait live.session.setModel(model);\n\t\t\t\t}\n\t\t\t\treturn live.session;\n\t\t\t}\n\n\t\t\tasync function close(): Promise {\n\t\t\t\topen.delete(handle);\n\t\t\t\tlet run = current;\n\t\t\t\tif (run) {\n\t\t\t\t\trun.stop();\n\t\t\t\t\tawait bounded(run.done, \"Atomic turn did not stop.\").catch(() => {});\n\t\t\t\t}\n\t\t\t\ttry {\n\t\t\t\t\tif (live) {\n\t\t\t\t\t\tlive.release();\n\t\t\t\t\t\tawait bounded(live.session.dispose(), \"Atomic session disposal timed out.\");\n\t\t\t\t\t}\n\t\t\t\t} finally {\n\t\t\t\t\tlive = undefined;\n\t\t\t\t\tif (directory) await rm(directory, { recursive: true, force: true });\n\t\t\t\t}\n\t\t\t}\n\n\t\t\tasync function stopped(): Promise {\n\t\t\t\tawait (closed ??= close());\n\t\t\t\treturn {\n\t\t\t\t\ttype: \"resume-session\",\n\t\t\t\t\tharnessId: \"atomic\",\n\t\t\t\t\tspecificationVersion: \"harness-v1\",\n\t\t\t\t\tdata: {},\n\t\t\t\t};\n\t\t\t}\n\n\t\t\tlet handle: HarnessV1Session = {\n\t\t\t\tsessionId: startOptions.sessionId,\n\t\t\t\tisResume: false,\n\n\t\t\t\tasync doPromptTurn(turn: HarnessV1PromptTurnOptions): Promise {\n\t\t\t\t\tif (closed) throw new Error(\"Atomic session is closed.\");\n\t\t\t\t\tif (current) throw new Error(\"Atomic session already has an active turn.\");\n\t\t\t\t\tlet text = promptText(turn.prompt);\n\t\t\t\t\tlet agent = await prepare(turn);\n\t\t\t\t\tlet structured = turn.responseFormat?.type === \"json\";\n\t\t\t\t\tlet names = full\n\t\t\t\t\t\t? agent.getAllTools().map(tool => tool.name).filter(name =>\n\t\t\t\t\t\t\tFULL_PLANNER_TOOLS.has(name) || policy.hostNames.includes(name)\n\t\t\t\t\t\t)\n\t\t\t\t\t\t: policy.hostNames;\n\t\t\t\t\tlet expected = structured ? [...names, ATOMIC_RESULT_TOOL_NAME] : names;\n\t\t\t\t\tagent.setActiveToolsByName(expected);\n\t\t\t\t\tif (!sameNames(agent.getActiveToolNames(), expected)) {\n\t\t\t\t\t\tthrow new ToolBoundaryError(\n\t\t\t\t\t\t\t`Atomic active tools do not match the turn: ${\n\t\t\t\t\t\t\t\tagent.getActiveToolNames().join(\", \")\n\t\t\t\t\t\t\t}.`,\n\t\t\t\t\t\t);\n\t\t\t\t\t}\n\t\t\t\t\tif (full) full.activeTools = names;\n\t\t\t\t\tpolicy.structured = structured;\n\t\t\t\t\tpolicy.systemPrompt = turnSystemPrompt(turn.instructions, turn.responseFormat);\n\t\t\t\t\tpolicy.result = undefined;\n\n\t\t\t\t\tlet run: Run = {\n\t\t\t\t\t\temit: turn.emit,\n\t\t\t\t\t\tpending: new Map(),\n\t\t\t\t\t\tblocks: new Map(),\n\t\t\t\t\t\tinputs: new Map(),\n\t\t\t\t\t\tstopped: false,\n\t\t\t\t\t\tstop: () => {\n\t\t\t\t\t\t\tif (run.stopped) return;\n\t\t\t\t\t\t\trun.stopped = true;\n\t\t\t\t\t\t\tfor (let resolve of run.pending.values()) {\n\t\t\t\t\t\t\t\tresolve({ output: \"The turn was aborted.\", isError: true });\n\t\t\t\t\t\t\t}\n\t\t\t\t\t\t\trun.pending.clear();\n\t\t\t\t\t\t\tvoid bounded(agent.abort(), \"Atomic abort timed out.\").catch(() => {});\n\t\t\t\t\t\t},\n\t\t\t\t\t\tdone: Promise.resolve(),\n\t\t\t\t\t};\n\t\t\t\t\tcurrent = run;\n\t\t\t\t\trun.done = (async () => {\n\t\t\t\t\t\ttry {\n\t\t\t\t\t\t\tif (!run.stopped) {\n\t\t\t\t\t\t\t\trun.emit({ type: \"stream-start\", modelId: agent.model?.id });\n\t\t\t\t\t\t\t\tawait agent.prompt(text, { expandPromptTemplates: !!full });\n\t\t\t\t\t\t\t}\n\t\t\t\t\t\t\tif (run.failure) throw run.failure;\n\t\t\t\t\t\t\tif (run.stopped) return;\n\t\t\t\t\t\t\tif (run.last?.stopReason === \"error\" || run.last?.stopReason === \"aborted\") {\n\t\t\t\t\t\t\t\tthrow new Error(run.last.errorMessage ?? \"Atomic turn failed.\");\n\t\t\t\t\t\t\t}\n\t\t\t\t\t\t\tif (structured) {\n\t\t\t\t\t\t\t\tif (!policy.result) {\n\t\t\t\t\t\t\t\t\tthrow new Error(\"Atomic turn ended without a structured result.\");\n\t\t\t\t\t\t\t\t}\n\t\t\t\t\t\t\t\tlet id = crypto.randomUUID();\n\t\t\t\t\t\t\t\trun.emit({ type: \"text-start\", id });\n\t\t\t\t\t\t\t\trun.emit({ type: \"text-delta\", id, delta: JSON.stringify(policy.result.value) });\n\t\t\t\t\t\t\t\trun.emit({ type: \"text-end\", id });\n\t\t\t\t\t\t\t}\n\t\t\t\t\t\t\trun.emit({\n\t\t\t\t\t\t\t\ttype: \"finish-step\",\n\t\t\t\t\t\t\t\tfinishReason: { unified: \"stop\", raw: undefined },\n\t\t\t\t\t\t\t\tusage: ZERO_USAGE,\n\t\t\t\t\t\t\t});\n\t\t\t\t\t\t\trun.emit({\n\t\t\t\t\t\t\t\ttype: \"finish\",\n\t\t\t\t\t\t\t\tfinishReason: { unified: \"stop\", raw: undefined },\n\t\t\t\t\t\t\t\ttotalUsage: ZERO_USAGE,\n\t\t\t\t\t\t\t});\n\t\t\t\t\t\t} finally {\n\t\t\t\t\t\t\tif (current === run) current = undefined;\n\t\t\t\t\t\t}\n\t\t\t\t\t})();\n\t\t\t\t\tlisten(run, turn.abortSignal);\n\t\t\t\t\treturn control(run);\n\t\t\t\t},\n\n\t\t\t\tasync doContinueTurn(turn): Promise {\n\t\t\t\t\tlet run = current;\n\t\t\t\t\tif (!run) throw unsupported(\"continuing a turn that is no longer running\");\n\t\t\t\t\trun.emit = turn.emit;\n\t\t\t\t\tlisten(run, turn.abortSignal);\n\t\t\t\t\treturn control(run);\n\t\t\t\t},\n\n\t\t\t\tasync doCompact() {\n\t\t\t\t\tthrow unsupported(\"compaction\");\n\t\t\t\t},\n\t\t\t\tasync doSuspendTurn() {\n\t\t\t\t\tthrow unsupported(\"suspending a turn\");\n\t\t\t\t},\n\t\t\t\tdoDetach: stopped,\n\t\t\t\tdoStop: stopped,\n\t\t\t\tasync doDestroy() {\n\t\t\t\t\tawait (closed ??= close());\n\t\t\t\t},\n\t\t\t};\n\t\t\topen.add(handle);\n\t\t\treturn handle;\n\t\t},\n\n\t\tasync shutdown() {\n\t\t\tawait Promise.allSettled([...open].map(session => session.doDestroy()));\n\t\t},\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",{"_55":56,"_139":140,"_141":142,"_143":144,"_145":146,"_147":148,"_149":150},"sources",[],"viewer","meta",{"_131":132,"_133":134,"_135":136,"_43":32,"_137":14,"_138":32,"_49":50,"_51":50},"branches",[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,14,127,128,129,130],"tags",[70,71,72,73],"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","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":50,"_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,"_53":174,"_175":32,"_176":174,"_177":159},{"_168":178,"_170":179,"_15":178,"_172":180,"_53":174,"_175":32,"_176":174,"_177":50},{"_168":169,"_170":171,"_15":169,"_172":173,"_53":174,"_175":32,"_176":174,"_177":163},"id","issues","name","Issues","filters",{},true,"saved","pinnable","count","tasks","Tasks",{},"Changes",{},{"_168":158,"_170":181,"_15":158,"_172":226,"_53":174,"_175":32,"_176":174},{"_168":178,"_170":179,"_15":178,"_172":225,"_53":174,"_175":32,"_176":174},{"_168":169,"_170":171,"_15":169,"_172":224,"_53":174,"_175":32,"_176":174},{"_168":221,"_170":222,"_15":221,"_172":223,"_53":32,"_175":32,"_176":174},{"_168":218,"_170":219,"_15":218,"_172":220,"_53":32,"_175":32,"_176":174},{"_168":153,"_170":216,"_15":145,"_172":217,"_53":32,"_175":32,"_176":174},{"_168":155,"_170":213,"_15":214,"_172":215,"_53":32,"_175":32,"_176":174},{"_168":151,"_170":211,"_15":151,"_172":212,"_53":32,"_175":32,"_176":174},{"_168":207,"_170":208,"_15":209,"_172":210,"_53":32,"_175":32,"_176":174},{"_168":141,"_170":205,"_15":141,"_172":206,"_53":32,"_175":32,"_176":32},{"_168":202,"_170":203,"_15":202,"_172":204,"_53":32,"_175":32,"_176":32},{"_168":199,"_170":200,"_15":199,"_172":201,"_53":32,"_175":32,"_176":32},{"_168":196,"_170":197,"_15":196,"_172":198,"_53":32,"_175":32,"_176":32},"decisions","Decisions",{},"changelog","Changelog",{},"roadmap","Roadmap",{},"Documents",{},"activity","Activity","insights",{},"Releases",{},"Deployments","automations/deployments",{},"Workflows",{},"discussions","Discussions",{},"goals","Goals",{},{},{},{},"groups","user","agents",[],"now",1794437216922,"sidebar","expanded"]