[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10,"_11":12},"actionData","errors","root",{"_229":-5,"_232":233,"_234":235},"routes/shell",{"_42":43,"_228":-5,"_229":-5,"_230":231},"routes/repo",{"_33":-7,"_34":35,"_36":37,"_38":39,"_40":41,"_42":43,"_44":31,"_45":31,"_46":31,"_47":31,"_48":31,"_49":31,"_50":51,"_52":51,"_53":31,"_54":-7,"_55":-7,"_56":57,"_58":59,"_60":61,"_62":-5,"_63":64,"_65":66,"_67":68,"_69":70},"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","a411df736ce67d745f267a89fe5d2a6b614e2a0d","path","apps/server/src/harness/atomic/adapter.ts","oid","ed044b6a2354d1c5faa323ff624f6357a0743170","size",22764,"commit","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 and coding tools, the operator's Atomic resources, a\n * channel working directory, and Chopin as HostInput. Every other session (the\n * summary and research workers) stays isolated: only Chopin host tools, no host\n * resources, and a checked per-turn 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 } 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\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};\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\ntype Run = {\n\temit: (part: HarnessV1StreamPart) => void;\n\tpending: Map void>;\n\tblocks: 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 (!(\"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} 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\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 ? {} : {\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: [atomicTurnExtension(policy)],\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\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\tawait session.dispose();\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.getActiveToolNames().filter(name => name !== ATOMIC_RESULT_TOOL_NAME)\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\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\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","organization",true,"site","nexthub","private","admin","settings","maintainer","triage","starred","stars",0,"watchers","watching","pinned","notify","views",[184,185,186,187,188,189,190,191,192,193,194,195,196],"navigation",{"_56":57,"_141":142,"_143":144,"_145":146,"_147":148,"_149":150,"_151":152},"sources",[],"viewer","meta",{"_133":134,"_135":136,"_137":138,"_44":31,"_139":128,"_140":31,"_50":51,"_52":51},"branches",[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,131,132],"tags",[71,72,73,74],"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",[167,168,169],"documents",{"_162":163,"_164":165},"code",{"_158":159,"_160":161},"automations",{"_155":156,"_157":-5},"delivery",{"_153":51,"_154":-5},"tag","04zvKQ8QOrDUF8TO1Ovz0Zy8_TT","releases","applications","workflows",3,"deployments","commits",1000,"changes",13,"counts",{"_166":165},"total",11,"issue",{"_170":160,"_172":182,"_15":160,"_174":183,"_54":41,"_176":31,"_177":41,"_178":161},{"_170":179,"_172":180,"_15":179,"_174":181,"_54":41,"_176":31,"_177":41,"_178":51},{"_170":171,"_172":173,"_15":171,"_174":175,"_54":41,"_176":31,"_177":41,"_178":165},"id","issues","name","Issues","filters",{},"saved","pinnable","count","tasks","Tasks",{},"Changes",{},{"_170":160,"_172":182,"_15":160,"_174":227,"_54":41,"_176":31,"_177":41},{"_170":179,"_172":180,"_15":179,"_174":226,"_54":41,"_176":31,"_177":41},{"_170":171,"_172":173,"_15":171,"_174":225,"_54":41,"_176":31,"_177":41},{"_170":222,"_172":223,"_15":222,"_174":224,"_54":31,"_176":31,"_177":41},{"_170":219,"_172":220,"_15":219,"_174":221,"_54":31,"_176":31,"_177":41},{"_170":155,"_172":217,"_15":147,"_174":218,"_54":31,"_176":31,"_177":41},{"_170":157,"_172":214,"_15":215,"_174":216,"_54":31,"_176":31,"_177":41},{"_170":153,"_172":212,"_15":153,"_174":213,"_54":31,"_176":31,"_177":41},{"_170":208,"_172":209,"_15":210,"_174":211,"_54":31,"_176":31,"_177":41},{"_170":143,"_172":206,"_15":143,"_174":207,"_54":31,"_176":31,"_177":31},{"_170":203,"_172":204,"_15":203,"_174":205,"_54":31,"_176":31,"_177":31},{"_170":200,"_172":201,"_15":200,"_174":202,"_54":31,"_176":31,"_177":31},{"_170":197,"_172":198,"_15":197,"_174":199,"_54":31,"_176":31,"_177":31},"decisions","Decisions",{},"changelog","Changelog",{},"roadmap","Roadmap",{},"Documents",{},"activity","Activity","insights",{},"Releases",{},"Deployments","automations/deployments",{},"Workflows",{},"discussions","Discussions",{},"goals","Goals",{},{},{},{},"groups","user","agents",[],"now",1794648471383,"sidebar","expanded"]