[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10,"_11":12},"actionData","errors","root",{"_271":-5,"_274":275,"_276":277},"routes/shell",{"_40":41,"_270":-5,"_271":-5,"_272":273},"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","cf89a0f2bb59cd56f584b4df17c24cdc406cc99e","path","packages/channel/src/channel.ts","oid","36d0860c1138000dd86569839c7dac8de298a36c","size",22592,"commit","mounts",[],"source","plain",{"_13":14,"_15":16},"kind","text","import { getSupportedThinkingLevels, type Models } from \"@earendil-works/pi-ai\";\nimport { BACKGROUND_CONTEXT as context } from \"@earendil-works/chord/context\";\nimport {\n\tAgentDoc,\n\ttype AgentEvent,\n\ttype Conversation,\n\ttype ConversationId,\n\ttype ConversationRecord,\n\tcreateRegistry,\n\ttype Cursor,\n\tdefineDoc,\n\tdefineExtension,\n\ttype EntryRecord,\n\tHarness,\n\tLiveDoc,\n\tROOT_CONVERSATION_ID,\n\ttype Storage,\n\ttype SubmissionId,\n\tToolResultEntry,\n\tUsageDoc,\n\ttype UsageState,\n\twatchEvents,\n} from \"@earendil-works/pi-durable\";\nimport type { ExecutionEnv } from \"@earendil-works/pi-durable/env\";\nimport { CodingTools } from \"@earendil-works/pi-durable/tools\";\n\nimport { type Directory, messaging, Subagent } from \"./agents\";\nimport { instructions } from \"./context\";\nimport { changes, patch } from \"./changes\";\nimport { type Desktop, desktop } from \"./desktop\";\nimport { lanes, LanesDoc } from \"./lanes\";\nimport { failure, type Log, logging, scoped } from \"./log\";\nimport { metadata, MetadataDoc, validateName } from \"./metadata\";\nimport { available, choose } from \"./models\";\nimport type {\n\tChannelInfo,\n\tChat,\n\tChatId,\n\tEffort,\n\tEvent,\n\tMetadata,\n\tModelRef,\n\tRequest,\n\tUsage,\n} from \"./protocol\";\nimport * as room from \"./room\";\n\nconst SettingsDoc = defineDoc<{ shared: boolean }>({\n\tkind: \"ace.settings\",\n\tversion: 1,\n\tscope: \"session\",\n\tinitial: () => ({ shared: true }),\n});\n\n/** Inactivity is measured in hours, so activity is published at most this often. */\nconst ACTIVITY_INTERVAL = 5 * 60_000;\n\nexport type Options = {\n\tid: string;\n\tname: string;\n\t/** Existing and explicitly named channels keep their name until a requested rename. */\n\tnamed?: boolean;\n\t/** Immutable Git branch prefix, seeded from the channel's initial name. */\n\tprefix?: string;\n\towner: string;\n\t/** Paths inside the execution environment's file system. */\n\tproject: string;\n\tlanes: string;\n\tmodel?: ModelRef;\n\t/** The host's current preference, consulted only for a chat's first agent invocation. */\n\tdefaultModel?(): Promise;\n\tstorage: Storage;\n\tmodels: Models;\n\tenv(cwd: string): ExecutionEnv;\n\tdesktop?: Desktop;\n\tdirectory: Directory;\n\t/** Publish a projection of committed metadata to the runtime's channel catalog. */\n\tonMetadata?(value: Metadata): void;\n\t/** Publish when the transcript last grew, in epoch milliseconds. */\n\tonActivity?(at: number): void;\n\t/** Rebuildable channel-wide projection of pi live runs, including child chats. */\n\tonBusy?(busy: boolean): void;\n\tlog: Log;\n};\n\ntype Send = (event: Event) => void;\n\nexport class Channel {\n\t#options: Options;\n\t#harness: Harness;\n\t#log: Log;\n\t#metadata: Metadata;\n\t#active = 0;\n\t#runs = new Set();\n\t#publishedBusy?: boolean;\n\t#unsubscribe?: () => void;\n\t#admissions = new Map>();\n\t#listeners = new Set<{ chat: ChatId; send: Send }>();\n\n\tprivate constructor(options: Options, harness: Harness, log: Log, value: Metadata) {\n\t\tthis.#options = options;\n\t\tthis.#harness = harness;\n\t\tthis.#log = log;\n\t\tthis.#metadata = value;\n\t}\n\n\tstatic async open(options: Options): Promise {\n\t\tconst log = scoped(options.log, { channel: options.id });\n\t\tlet channel: Channel;\n\t\tconst registry = createRegistry();\n\t\tregistry.install(logging(log));\n\t\tregistry.install(CodingTools);\n\t\tif (options.desktop) registry.install(desktop(options.desktop));\n\t\tregistry.install(lanes({ ...options, name: options.prefix || options.name }));\n\t\tregistry.install(Subagent);\n\t\tregistry.install(metadata((value) => channel.#changed(value)));\n\t\tregistry.install(messaging(options.directory));\n\t\tregistry.install(\n\t\t\tdefineExtension({ name: \"ace-channel\", sections: [room.section(options), instructions] }),\n\t\t);\n\t\tconst harness = await Harness.open(options.storage, {\n\t\t\tmodels: options.models,\n\t\t\tregistry,\n\t\t\tenv: ({ cwd }) => options.env(cwd || options.project),\n\t\t\tonReport: (error) => log(\"error\", \"harness.report\", failure(error)),\n\t\t}, context);\n\t\tawait harness.root(context, { agent: { model: options.model, cwd: options.project } });\n\t\tconst value = await harness.commit(async (tx) => {\n\t\t\tconst doc = await tx.doc(MetadataDoc);\n\t\t\t// A missing document is the version 0 upgrade; existing pi metadata always wins.\n\t\t\tif (!doc.name) {\n\t\t\t\tdoc.name = options.name;\n\t\t\t\tdoc.named = options.named ?? true;\n\t\t\t}\n\t\t\treturn { name: doc.name, summary: doc.summary, revision: doc.revision };\n\t\t}, context);\n\t\tchannel = new Channel(options, harness, log, value);\n\t\tchannel.#changed(value);\n\t\t// Scheduling has not resumed and no caller has this channel yet, so the initial snapshot\n\t\t// and subscription cannot miss a run transition. LiveDoc forks start empty in pi.\n\t\tawait channel.#snapshotBusy();\n\t\tchannel.#unsubscribe = harness.subscribeCommits(({ changes }) => {\n\t\t\tfor (const change of changes) {\n\t\t\t\tif (change.type !== \"document\" || change.record.kind !== LiveDoc.definition.kind) continue;\n\t\t\t\tconst { scope } = change.record;\n\t\t\t\tif (scope.kind !== \"conversation\") continue;\n\t\t\t\tif (change.value?.run) channel.#runs.add(scope.conversationId);\n\t\t\t\telse channel.#runs.delete(scope.conversationId);\n\t\t\t}\n\t\t\t// Publish once per atomic commit, not once per chat or streaming delta.\n\t\t\tchannel.#publishBusy();\n\t\t\tif (changes.some((change) => change.type === \"entry\")) channel.#activity();\n\t\t});\n\t\t// Opening resumes work a crash interrupted; a killed channel left only terminal tasks behind.\n\t\tharness.resume();\n\t\tlog(\"info\", \"channel.open\", { name: value.name, project: options.project });\n\t\treturn channel;\n\t}\n\n\t/** Runs a client request, logging its outcome with the caller's `trace` id. */\n\tasync handle(request: Request, send: Send, trace?: string): Promise {\n\t\tconst start = Date.now();\n\t\tconst fields = {\n\t\t\t...(trace ? { trace } : {}),\n\t\t\top: request.op,\n\t\t\t...(\"chat\" in request && request.chat !== undefined ? { chat: request.chat } : {}),\n\t\t\t...(\"author\" in request ? { author: request.author } : {}),\n\t\t\t...(\"requestId\" in request && request.requestId ? { requestId: request.requestId } : {}),\n\t\t\t...(\"model\" in request && request.model ? { model: request.model } : {}),\n\t\t};\n\t\ttry {\n\t\t\tconst value = await this.#handle(request, send);\n\t\t\t// Watches and polls are constant traffic; their failures still log below.\n\t\t\tconst level = request.op === \"watch\" || request.op === \"info\" || request.op === \"models\"\n\t\t\t\t? \"debug\"\n\t\t\t\t: \"info\";\n\t\t\tthis.#log(level, \"request\", { ...fields, ms: Date.now() - start, ...result(value) });\n\t\t\treturn value;\n\t\t} catch (error) {\n\t\t\t// Refused requests are expected; their message is enough.\n\t\t\tconst message = error instanceof Error ? error.message : String(error);\n\t\t\tthis.#log(\"warn\", \"request.failed\", { ...fields, ms: Date.now() - start, error: message });\n\t\t\tthrow error;\n\t\t}\n\t}\n\n\tasync #handle(request: Request, send: Send): Promise {\n\t\tswitch (request.op) {\n\t\t\tcase \"info\":\n\t\t\t\treturn this.info();\n\t\t\tcase \"models\":\n\t\t\t\treturn available(this.#options.models);\n\t\t\tcase \"say\":\n\t\t\t\treturn this.#say(request);\n\t\t\tcase \"ask\":\n\t\t\t\treturn this.#ask(request);\n\t\t\tcase \"chat\":\n\t\t\t\treturn this.#chat(request);\n\t\t\tcase \"stop\":\n\t\t\t\treturn (await this.#conversation(request.chat)).abort(context);\n\t\t\tcase \"kill\":\n\t\t\t\treturn this.kill();\n\t\t\tcase \"share\":\n\t\t\t\treturn this.#share(request);\n\t\t\tcase \"rename\":\n\t\t\t\treturn this.#rename(request);\n\t\t\tcase \"watch\":\n\t\t\t\treturn this.#watch(request.chat, send);\n\t\t\tcase \"changes\": {\n\t\t\t\tconst { cwd, lane } = await this.#place(request.chat);\n\t\t\t\treturn changes(this.#options.env(cwd), cwd, this.#options.project, lane, context);\n\t\t\t}\n\t\t\tcase \"patch\": {\n\t\t\t\tconst { cwd, lane } = await this.#place(request.chat);\n\t\t\t\tconst { env, project } = this.#options;\n\t\t\t\treturn patch(env(cwd), cwd, project, lane?.base, request.file, context);\n\t\t\t}\n\t\t\tcase \"wait\": {\n\t\t\t\tconst submission = await this.#harness.submission(\n\t\t\t\t\trequest.submission as SubmissionId,\n\t\t\t\t\tcontext,\n\t\t\t\t);\n\t\t\t\tif (!submission) throw new Error(`Unknown submission ${request.submission}`);\n\t\t\t\treturn (await submission.wait(context)).status;\n\t\t\t}\n\t\t}\n\t}\n\n\tasync info(): Promise {\n\t\tconst { id, project, owner } = this.#options;\n\t\tconst settings = await this.#harness.snapshot(SettingsDoc, context);\n\t\tconst { name, summary, revision } = (await this.#harness.snapshot(MetadataDoc, context))!;\n\t\tconst records: ConversationRecord[] = [];\n\t\tlet cursor: Cursor | undefined;\n\t\tdo {\n\t\t\tconst page = await this.#harness.commit(\n\t\t\t\t(tx) => tx.scanConversations({}, 256, cursor),\n\t\t\t\tcontext,\n\t\t\t);\n\t\t\trecords.push(...page.items);\n\t\t\tcursor = page.next;\n\t\t} while (cursor);\n\t\tconst lanes = (await this.#harness.snapshot(LanesDoc, context))?.lanes || {};\n\t\tconst byPath = new Map(Object.entries(lanes).map(([lane, { path }]) => [path, lane]));\n\t\tconst chats: Chat[] = await Promise.all(records.map(async (record) => {\n\t\t\tconst [agent, live, spent] = await Promise.all([\n\t\t\t\tthis.#harness.snapshot(AgentDoc, record.id, context),\n\t\t\t\tthis.#harness.snapshot(LiveDoc, record.id, context),\n\t\t\t\tthis.#harness.snapshot(UsageDoc, record.id, context),\n\t\t\t]);\n\t\t\tconst lane = agent?.cwd && byPath.get(agent.cwd);\n\t\t\tconst chat: Chat = { id: record.id, busy: !!live?.run, usage: usage(spent) };\n\t\t\tconst window = agent?.model\n\t\t\t\t&& this.#options.models.getModel(agent.model.provider, agent.model.modelId)?.contextWindow;\n\t\t\tconst used = window && await this.#used(record.id);\n\t\t\tif (window && used) chat.context = { used, window };\n\t\t\tif (record.owner) chat.parent = record.owner.conversationId;\n\t\t\tif (agent?.model) chat.model = agent.model;\n\t\t\tchat.effort = agent?.thinkingLevel || \"off\";\n\t\t\tif (lane) chat.lane = lane;\n\t\t\treturn chat;\n\t\t}));\n\t\treturn { id, name, summary, revision, project, owner, shared: settings?.shared ?? true, chats };\n\t}\n\n\t/** The newest response's own token count; providers report what that request carried. */\n\tasync #used(id: ConversationId): Promise {\n\t\tconst conversation = await this.#harness.conversation(id, context);\n\t\tconst { messages } = await conversation!.context(context);\n\t\tfor (let index = messages.length - 1; index >= 0; index--) {\n\t\t\tconst message = messages[index]!;\n\t\t\tif (message.role !== \"assistant\") continue;\n\t\t\tconst { input, output, cacheRead, cacheWrite } = message.usage;\n\t\t\tconst total = input + output + cacheRead + cacheWrite;\n\t\t\t// A failed or aborted request reports nothing; the context is what the last real one carried.\n\t\t\tif (total) return total;\n\t\t}\n\t}\n\n\tget busy(): boolean {\n\t\treturn this.#runs.size > 0;\n\t}\n\n\tasync isIdle(): Promise {\n\t\treturn !this.busy;\n\t}\n\n\tasync #snapshotBusy(): Promise {\n\t\tlet cursor: Cursor | undefined;\n\t\tdo {\n\t\t\tconst page = await this.#harness.commit(\n\t\t\t\t(tx) => tx.scanConversations({}, 256, cursor),\n\t\t\t\tcontext,\n\t\t\t);\n\t\t\tfor (const { id } of page.items) {\n\t\t\t\tconst live = await this.#harness.snapshot(LiveDoc, id, context);\n\t\t\t\tif (live?.run) this.#runs.add(id);\n\t\t\t}\n\t\t\tcursor = page.next;\n\t\t} while (cursor);\n\t\tthis.#publishBusy();\n\t}\n\n\t#publishBusy(): void {\n\t\tconst busy = this.busy;\n\t\tif (busy === this.#publishedBusy) return;\n\t\ttry {\n\t\t\tthis.#options.onBusy?.(busy);\n\t\t\tthis.#publishedBusy = busy;\n\t\t} catch (error) {\n\t\t\tthis.#log(\"warn\", \"busy.publish\", failure(error));\n\t\t}\n\t}\n\n\t/** Durably abort every chat's work, including background subagents, so reopening resumes none of it. */\n\tasync kill(): Promise {\n\t\tconst { chats } = await this.info();\n\t\tthis.#log(\"warn\", \"channel.kill\", {\n\t\t\tchats: chats.filter((chat) => chat.busy).map((c) => c.id),\n\t\t});\n\t\tawait Promise.all(chats.map(async (chat) => {\n\t\t\tconst conversation = await this.#harness.conversation(chat.id as ConversationId, context);\n\t\t\tawait conversation?.abort(context, { background: true });\n\t\t}));\n\t}\n\n\tasync close(): Promise {\n\t\tthis.#log(\"info\", \"channel.close\");\n\t\tthis.#unsubscribe?.();\n\t\ttry {\n\t\t\tawait this.#harness.close(context);\n\t\t} finally {\n\t\t\tthis.#runs.clear();\n\t\t\tthis.#publishBusy();\n\t\t}\n\t}\n\n\t/** Where a chat works: its current lane's worktree, or the project checkout before it has one. */\n\tasync #place(\n\t\tchat: ChatId | undefined,\n\t): Promise<{ cwd: string; lane?: { name: string; base?: string } }> {\n\t\tconst { id } = await this.#conversation(chat);\n\t\tconst cwd = (await this.#harness.snapshot(AgentDoc, id, context))?.cwd || this.#options.project;\n\t\tconst lanes = (await this.#harness.snapshot(LanesDoc, context))?.lanes || {};\n\t\tconst found = Object.entries(lanes).find(([, value]) => value.path === cwd);\n\t\tif (!found) return { cwd };\n\t\tconst [name, { base }] = found;\n\t\treturn { cwd, lane: base ? { name, base } : { name } };\n\t}\n\n\tasync #conversation(chat: ChatId | undefined): Promise {\n\t\tconst conversation = await this.#harness.conversation(\n\t\t\t(chat ?? ROOT_CONVERSATION_ID) as ConversationId,\n\t\t\tcontext,\n\t\t);\n\t\tif (!conversation) throw new Error(`No chat ${chat}`);\n\t\treturn conversation;\n\t}\n\n\t#author(author: string) {\n\t\tif (!room.isAuthor(author)) throw new Error(`Invalid author ${author}`);\n\t}\n\n\tasync #say(request: Extract) {\n\t\tthis.#author(request.author);\n\t\tconst conversation = await this.#conversation(request.chat);\n\t\troom.checkImages(request.images);\n\t\tconst entry = room.draft(request.author, request.text, Date.now(), request.images);\n\t\tconst submission = await conversation.submit({\n\t\t\ttype: \"write\",\n\t\t\tentry,\n\t\t\t...(request.requestId ? { requestId: request.requestId } : {}),\n\t\t}, context);\n\t\treturn { submission: submission.id };\n\t}\n\n\tasync #ask(request: Extract) {\n\t\tconst chat = request.chat || ROOT_CONVERSATION_ID;\n\t\tconst previous = this.#admissions.get(chat) || Promise.resolve();\n\t\t// Selection and submission must stay together across concurrent clients.\n\t\tconst pending = previous.catch(() => {}).then(() => this.#admit(request));\n\t\tthis.#admissions.set(chat, pending);\n\t\ttry {\n\t\t\treturn await pending;\n\t\t} finally {\n\t\t\tif (this.#admissions.get(chat) === pending) this.#admissions.delete(chat);\n\t\t}\n\t}\n\n\tasync #admit(request: Extract) {\n\t\tthis.#author(request.author);\n\t\troom.checkImages(request.images);\n\t\tconst settings = await this.#harness.snapshot(SettingsDoc, context);\n\t\tconst isOwner = request.author === this.#options.owner;\n\t\tif (!isOwner && settings?.shared === false) {\n\t\t\tthrow new Error(\"Only the owner can invoke agents here\");\n\t\t}\n\t\tconst conversation = await this.#conversation(request.chat);\n\t\tawait this.#select(conversation, request.model, request.effort);\n\t\tconst submission = await conversation.submit({\n\t\t\ttype: \"input\",\n\t\t\tcontent: room.content(request.author, request.text, request.images),\n\t\t\twhenBusy: \"steer\",\n\t\t\t...(request.requestId ? { requestId: request.requestId } : {}),\n\t\t}, context);\n\t\treturn { submission: submission.id };\n\t}\n\n\t/** Model and effort apply to a whole run, never just its later turns. */\n\tasync #select(conversation: Conversation, requested: ModelRef | undefined, effort?: Effort) {\n\t\tconst agent = await conversation.agent(context);\n\t\tconst current = agent.model;\n\t\tconst model = requested || current || await (\n\t\t\tthis.#options.defaultModel?.() || choose(this.#options.models)\n\t\t);\n\t\tconst selected = this.#options.models.getModel(model.provider, model.modelId);\n\t\tif (!selected) {\n\t\t\tthrow new Error(`Unknown model ${model.provider}/${model.modelId}`);\n\t\t}\n\t\tconst levels = getSupportedThinkingLevels(selected);\n\t\tif (effort !== undefined && effort !== \"off\" && !levels.includes(effort)) {\n\t\t\tthrow new Error(\n\t\t\t\t`Unsupported reasoning effort ${effort} for ${model.provider}/${model.modelId}`,\n\t\t\t);\n\t\t}\n\t\t// Pi's \"off\" means omit reasoning, allowing provider defaults on always-thinking models.\n\t\tconst thinkingLevel = effort\n\t\t\t|| (levels.includes(agent.thinkingLevel) ? agent.thinkingLevel : \"off\");\n\t\tconst sameModel = current?.provider === model.provider && current.modelId === model.modelId;\n\t\tconst same = sameModel && thinkingLevel === agent.thinkingLevel;\n\t\tconst live = await this.#harness.snapshot(LiveDoc, conversation.id, context);\n\t\tif (!same && live?.run) {\n\t\t\tthrow new Error(\n\t\t\t\t\"The chat is busy; stop it or wait before changing its model or reasoning effort\",\n\t\t\t);\n\t\t}\n\t\tconst available = await this.#options.models.getAvailable(model.provider);\n\t\tif (!available.some((value) => value.id === model.modelId)) {\n\t\t\tthrow new Error(\n\t\t\t\t`Configure ${model.provider} for this channel before invoking an agent. Chat is still available.`,\n\t\t\t);\n\t\t}\n\t\tif (same) return;\n\t\tawait conversation.configure({ model, thinkingLevel }, context);\n\t}\n\n\tasync #chat(request: Extract) {\n\t\tthis.#author(request.author);\n\t\tconst conversation = await this.#harness.createConversation({\n\t\t\townership: { kind: \"ownerless\" },\n\t\t\tagent: { model: request.model || this.#options.model, cwd: this.#options.project },\n\t\t}, context);\n\t\treturn { chat: conversation.id };\n\t}\n\n\tasync #share(request: Extract) {\n\t\tif (request.author !== this.#options.owner) {\n\t\t\tthrow new Error(\"Only the owner can change sharing\");\n\t\t}\n\t\tawait this.#harness.commit(async (tx) => {\n\t\t\t(await tx.doc(SettingsDoc)).shared = request.shared;\n\t\t}, context);\n\t}\n\n\tasync #rename(request: Extract): Promise {\n\t\tif (request.author !== this.#options.owner) {\n\t\t\tthrow new Error(\"Only the owner can rename the channel\");\n\t\t}\n\t\tconst name = validateName(request.name);\n\t\tconst value = await this.#harness.commit(async (tx) => {\n\t\t\tconst doc = await tx.doc(MetadataDoc);\n\t\t\tif (doc.name !== name) doc.revision++;\n\t\t\tdoc.name = name;\n\t\t\tdoc.named = true;\n\t\t\treturn { name: doc.name, summary: doc.summary, revision: doc.revision };\n\t\t}, context);\n\t\tthis.#changed(value);\n\t\treturn value;\n\t}\n\n\t#changed(value: Metadata): void {\n\t\tif (value.revision < this.#metadata.revision) return;\n\t\tthis.#metadata = value;\n\t\ttry {\n\t\t\tthis.#options.onMetadata?.(value);\n\t\t} catch (error) {\n\t\t\tthis.#log(\"warn\", \"metadata.publish\", failure(error));\n\t\t}\n\t\tfor (const listener of this.#listeners) {\n\t\t\ttry {\n\t\t\t\tlistener.send({ kind: \"metadata\", chat: listener.chat, ...value });\n\t\t\t} catch {\n\t\t\t\tthis.#listeners.delete(listener);\n\t\t\t}\n\t\t}\n\t}\n\n\t#activity(): void {\n\t\tconst now = Date.now();\n\t\tif (now - this.#active < ACTIVITY_INTERVAL) return;\n\t\tthis.#active = now;\n\t\ttry {\n\t\t\tthis.#options.onActivity?.(now);\n\t\t} catch (error) {\n\t\t\tthis.#log(\"warn\", \"activity.publish\", failure(error));\n\t\t}\n\t}\n\n\t/** Replays the chat's active transcript, then streams. Resolves when the stream ends. */\n\tasync #watch(chat: ChatId | undefined, send: Send) {\n\t\tconst conversation = await this.#conversation(chat);\n\t\tconst stream = await watchEvents(this.#harness, conversation.id, context);\n\t\tconst listener = { chat: conversation.id, send };\n\t\tthis.#listeners.add(listener);\n\t\tvoid stream.closed.then(() => this.#listeners.delete(listener));\n\t\tsend({ kind: \"metadata\", chat: conversation.id, ...this.#metadata });\n\t\tfor (const entry of stream.snapshot.entries) for (const event of events(entry)) send(event);\n\t\tif (stream.snapshot.run) send({ kind: \"run\", chat: conversation.id, state: \"start\" });\n\t\tsend({ kind: \"live\", chat: conversation.id });\n\t\tstream.start(async (batch) => {\n\t\t\tfor (const event of batch) for (const mapped of live(conversation.id, event)) send(mapped);\n\t\t});\n\t\treturn {\n\t\t\tstop: () => {\n\t\t\t\tthis.#listeners.delete(listener);\n\t\t\t\treturn stream.stop();\n\t\t\t},\n\t\t};\n\t}\n}\n\nfunction usage(state: Readonly | undefined): Usage {\n\tconst total: Usage = {\n\t\tinput: 0,\n\t\toutput: 0,\n\t\tcacheRead: 0,\n\t\tcacheWrite: 0,\n\t\ttotalTokens: 0,\n\t\tcost: 0,\n\t};\n\tif (!state) return total;\n\tfor (const bucket of [state.models, state.tools]) {\n\t\tfor (const value of Object.values(bucket)) {\n\t\t\ttotal.input += value.input;\n\t\t\ttotal.output += value.output;\n\t\t\ttotal.cacheRead += value.cacheRead;\n\t\t\ttotal.cacheWrite += value.cacheWrite;\n\t\t\ttotal.totalTokens += value.totalTokens;\n\t\t\ttotal.cost += value.cost.total;\n\t\t}\n\t}\n\treturn total;\n}\n\n/** Submission and chat ids a request produced, so later lines can be traced back to it. */\nfunction result(value: unknown) {\n\tif (!value || typeof value !== \"object\") {\n\t\treturn typeof value === \"string\"\n\t\t\t? { result: value }\n\t\t\t: {};\n\t}\n\tconst { submission, chat } = value as { submission?: number; chat?: number };\n\treturn { ...(submission ? { submission } : {}), ...(chat ? { created: chat } : {}) };\n}\n\n/** Providers append their JSON error body; its message is the part a person can act on. */\nfunction readable(error: string | undefined): string {\n\tif (!error) return \"The provider failed the response\";\n\tconst start = error.indexOf(\"{\");\n\tif (start < 0) return error;\n\ttry {\n\t\tconst body = JSON.parse(error.slice(start));\n\t\tconst detail = body.message ?? body.error?.message;\n\t\treturn typeof detail === \"string\" ? `${error.slice(0, start).trim()} ${detail}` : error;\n\t} catch {\n\t\treturn error;\n\t}\n}\n\nfunction live(chat: ChatId, event: AgentEvent): Event[] {\n\tif (event.type === \"message_end\") return events(event.entry);\n\tif (event.type === \"message_update\") {\n\t\tconst text = event.changes.flatMap((change) =>\n\t\t\tchange.type === \"text_delta\" ? [change.delta] : []\n\t\t).join(\"\");\n\t\treturn text ? [{ kind: \"delta\", chat, text }] : [];\n\t}\n\tif (event.type === \"run_start\") return [{ kind: \"run\", chat, state: \"start\" }];\n\tif (event.type === \"run_end\") return [{ kind: \"run\", chat, state: \"end\" }];\n\treturn [];\n}\n\nfunction events(entry: EntryRecord): Event[] {\n\tconst chat = entry.conversationId;\n\tconst human = room.human(entry);\n\tif (human) return [{ kind: \"message\", chat, entry: entry.id, ...human }];\n\tconst message = entry.model?.[0];\n\tif (message?.role === \"assistant\") {\n\t\tconst out: Event[] = [];\n\t\tconst text = room.text(message);\n\t\tconst at = message.timestamp;\n\t\tconst model = message.model;\n\t\tconst error = message.stopReason === \"error\";\n\t\tconst stopped = message.stopReason === \"aborted\";\n\t\tif (text || error || stopped) {\n\t\t\tout.push({\n\t\t\t\tkind: \"reply\",\n\t\t\t\tchat,\n\t\t\t\tentry: entry.id,\n\t\t\t\tat,\n\t\t\t\tmodel,\n\t\t\t\ttext,\n\t\t\t\t...(error ? { error: readable(message.errorMessage) } : {}),\n\t\t\t\t...(stopped ? { stopped } : {}),\n\t\t\t});\n\t\t}\n\t\tfor (const block of message.content) {\n\t\t\tif (block.type !== \"toolCall\") continue;\n\t\t\tout.push({\n\t\t\t\tkind: \"tool\",\n\t\t\t\tchat,\n\t\t\t\tat,\n\t\t\t\tmodel,\n\t\t\t\tcall: block.id,\n\t\t\t\tname: block.name,\n\t\t\t\targs: block.arguments,\n\t\t\t});\n\t\t}\n\t\treturn out;\n\t}\n\tif (message?.role === \"toolResult\") {\n\t\tconst stopped = ToolResultEntry.is(entry)\n\t\t\t&& entry.data.diagnostics.some(({ code }) => code === \"aborted\");\n\t\tconst images = room.images(message);\n\t\treturn [{\n\t\t\tkind: \"result\",\n\t\t\tchat,\n\t\t\tcall: message.toolCallId,\n\t\t\terror: message.isError,\n\t\t\ttext: room.text(message),\n\t\t\t...(images ? { images } : {}),\n\t\t\t...(stopped ? { stopped: true } : {}),\n\t\t}];\n\t}\n\treturn [];\n}\n","editable",false,"branch","documentNavigation","repo","githubnext/ace2","repoId","938fe4cd-5320-4e4f-ac7c-87d4dad8490c","ownerId","org:89615882","site","nexthub","private","admin","settings","maintainer","triage","starred","stars",0,"watchers","watching","pinned","notify","views",[226,227,228,229,230,231,232,233,234,235,236,237,238],"navigation",{"_54":55,"_182":183,"_184":185,"_186":187,"_188":189,"_190":191,"_192":193},"sources",[],"viewer","meta",{"_174":175,"_176":177,"_178":179,"_42":31,"_180":166,"_181":31,"_48":49,"_50":49},"branches",[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,133,134,135,136,137,138,139,140,141,142,143,144,145,146,147,148,149,150,151,152,153,154,155,156,157,158,159,160,161,162,163,164,165,166,167,168,169,170,171,172,173],"tags",[69,70,71,72,73,74,75,76,77,78,79,80],"cloneUrl","https://git.nexthub.sh/githubnext/ace2.git","desktop-canary-v0.0.10","desktop-canary-v0.0.11","desktop-canary-v0.0.12","desktop-canary-v0.0.13","desktop-canary-v0.0.14","desktop-canary-v0.0.15","desktop-canary-v0.0.16","desktop-canary-v0.0.18","desktop-canary-v0.0.21","desktop-canary-v0.0.7","desktop-canary-v0.0.8","desktop-canary-v0.0.9","amber-beacon/composer-effort","brisk-ember/github-avatars","brisk-grove/image-paste-91","calm-anchor/fix-streaming-draft-overlap","calm-grove/composer-agent-mode","cloud-pilot-ops/canary-0-0-17","cloud-pilot-ops/cloud-move","cloud-pilot-ops/cloud-pilot","codex/agentation-shortcut","codex/annotation-polish","codex/browser-pages","codex/canary-0-0-21","codex/canary-0.0.11","codex/channel-delete-close","codex/channel-watch-recovery","codex/clipboard-files-write","codex/composer-coordinate-check","codex/computer-use-validation","codex/desktop-actions","codex/desktop-app-search","codex/desktop-app-state","codex/desktop-availability","codex/desktop-click-variants","codex/desktop-clipboard","codex/desktop-clipboard-files","codex/desktop-clipboard-image","codex/desktop-clipboard-image-write","codex/desktop-clipboard-text","codex/desktop-drag","codex/desktop-keyboard","codex/desktop-launch","codex/desktop-locked-feedback","codex/desktop-menu-command","codex/desktop-menu-inventory","codex/desktop-minimize","codex/desktop-open","codex/desktop-pointer","codex/desktop-quit","codex/desktop-selection-keys","codex/desktop-tool-guidance","codex/desktop-tools-extraction","codex/desktop-window-close","codex/desktop-window-geometry","codex/desktop-windows","codex/dev-permission-identity","codex/durable-composer-drafts","codex/fix-message-clipping","codex/lane-base-96","codex/native-patch-prefix","codex/peekaboo","codex/peer-channel-messaging","codex/pixel-snapshot-authority","codex/publish-canary-0-0-21","codex/readme-security","codex/settings-refresh","codex/stale-click-refusal","codex/tab-renaming-api","codex/team-agent-access","codex/team-channel-sections","codex/team-dogfood-integration","codex/webkit-coordinate-window","codex/webkit-desktop-focus","deft-beacon/helper-isolation","deft-grove/align-avatar-byline","deft-grove/build-canary-0-0-18","deft-grove/canary-github-releases","deft-grove/ship-canary-0-0-18","deft-meadow/details-sidebar","fair-ember/canary-0-0-13","fair-ember/canary-0-0-14","fair-fjord/all-projects","feat/github-cache","feat/rebuild","fix/channel-credentials","glad-anchor/restore-message-queue","glad-ember/archive-inactive-channels","glad-fjord/project-identity","glad-orbit/channel-progress","glad-ridge/terminal-replay-input","hazy-anchor/github-row-actions","hazy-ember/channel-access-toggles","hazy-grove/all-projects-add-channel","local-project-setup/build-canary-0-0-20","local-project-setup/canary-0-0-20","local-project-setup/local-project-setup","main","mellow-ridge/canary-0-0-16","mellow-ridge/top-bar-drag-area","nimble-cedar/modal-top-offset","nimble-meadow/canary-0-0-15","remote-channel-load/build-canary-0-0-19","remote-channel-load/canary-0-0-19","remote-channel-load/fix-remote-channel-load","description","Ace: a collaborative coding environment on the team's own machines","owner","githubnext","section","","head","empty","pins",[208,209,210],"documents",{"_203":204,"_205":206},"code",{"_199":200,"_201":202},"automations",{"_196":197,"_198":-5},"delivery",{"_194":49,"_195":-5},"tag","9Rn62lcgXCFfpmCuooTjLxGyUf8","releases","applications","workflows",2,"deployments","commits",215,"changes",1,"counts",{"_207":206},"total",86,"issue",{"_211":201,"_213":224,"_15":201,"_215":225,"_52":217,"_218":31,"_219":217,"_220":202},{"_211":221,"_213":222,"_15":221,"_215":223,"_52":217,"_218":31,"_219":217,"_220":49},{"_211":212,"_213":214,"_15":212,"_215":216,"_52":217,"_218":31,"_219":217,"_220":206},"id","issues","name","Issues","filters",{},true,"saved","pinnable","count","tasks","Tasks",{},"Changes",{},{"_211":201,"_213":224,"_15":201,"_215":269,"_52":217,"_218":31,"_219":217},{"_211":221,"_213":222,"_15":221,"_215":268,"_52":217,"_218":31,"_219":217},{"_211":212,"_213":214,"_15":212,"_215":267,"_52":217,"_218":31,"_219":217},{"_211":264,"_213":265,"_15":264,"_215":266,"_52":31,"_218":31,"_219":217},{"_211":261,"_213":262,"_15":261,"_215":263,"_52":31,"_218":31,"_219":217},{"_211":196,"_213":259,"_15":188,"_215":260,"_52":31,"_218":31,"_219":217},{"_211":198,"_213":256,"_15":257,"_215":258,"_52":31,"_218":31,"_219":217},{"_211":194,"_213":254,"_15":194,"_215":255,"_52":31,"_218":31,"_219":217},{"_211":250,"_213":251,"_15":252,"_215":253,"_52":31,"_218":31,"_219":217},{"_211":184,"_213":248,"_15":184,"_215":249,"_52":31,"_218":31,"_219":31},{"_211":245,"_213":246,"_15":245,"_215":247,"_52":31,"_218":31,"_219":31},{"_211":242,"_213":243,"_15":242,"_215":244,"_52":31,"_218":31,"_219":31},{"_211":239,"_213":240,"_15":239,"_215":241,"_52":31,"_218":31,"_219":31},"decisions","Decisions",{},"changelog","Changelog",{},"roadmap","Roadmap",{},"Documents",{},"activity","Activity","insights",{},"Releases",{},"Deployments","automations/deployments",{},"Workflows",{},"discussions","Discussions",{},"goals","Goals",{},{},{},{},"groups","user","agents",[],"now",1794451350733,"sidebar","expanded"]