[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10,"_11":12},"actionData","errors","root",{"_228":-5,"_231":232,"_233":234},"routes/shell",{"_40":41,"_227":-5,"_228":-5,"_229":230},"routes/repo",{"_33":-7,"_34":35,"_36":37,"_38":39,"_40":41,"_42":31,"_43":31,"_44":31,"_45":31,"_46":31,"_47":31,"_48":49,"_50":49,"_51":31,"_52":-7,"_53":-7,"_54":55,"_56":57,"_58":59,"_60":-5,"_61":62,"_63":64,"_65":66,"_67":68},"routes/repo.blob",{"_13":14,"_15":16,"_17":18,"_19":20,"_21":14,"_22":23,"_24":-5,"_25":26,"_27":28,"_28":29,"_30":31,"_32":14},"ref","ca08ce3622748cbe65ba53ff9ee933fc41cf083d","path","apps/server/src/mcp/hosted.ts","oid","a7d8b2bd1cbfaa75ed6d7caf6aba33c65de6996a","size",21394,"commit","mounts",[],"source","plain",{"_13":14,"_15":16},"kind","text","import { documentPath, parseDocumentPath } from \"@chopin/protocol/document-url\";\n\nimport { deterministicChannelId, isChannelId } from \"../channels/id\";\nimport { documentSlug } from \"../channels/slug\";\nimport { GitHubError } from \"../github/client\";\nimport * as Plan from \"../plan/service\";\nimport * as Rooms from \"../rooms\";\nimport { claimImplementation, reportImplementationLifecycle } from \"../tasks/plan-graphs\";\nimport { StorageError } from \"../storage/errors\";\nimport { implementationLifecycle } from \"../tasks/lifecycle\";\n\nimport type { HostedAuth } from \"../auth/routes\";\nimport type { GitHubUser } from \"../github/client\";\nimport type {\n\tDocumentSummary,\n\tImplementation,\n\tImplementationInput,\n\tMcpOptions,\n\tRenameDocumentInput,\n} from \"../mcp\";\nimport type { LifecycleArguments } from \"./lifecycle\";\nimport type { ChannelArchiveResult, ChannelRecord, Lease } from \"../storage/model\";\nimport type { ClaimResult, Run } from \"../tasks/graphs\";\n\nexport type HostedCaller = {\n\toauthToken: string;\n\tuser: GitHubUser;\n};\n\nexport type ImplementationPersistence = { lease(): Lease };\nexport type HostedCallbacks = {\n\tarchiveChannel?: (channelId: string, now: Date) => Promise;\n\trestoreChannel?: (channelId: string, now: Date) => Promise;\n\tisChannelDeleting?: (channelId: string) => boolean;\n\tserializeDocument?: (channelId: string, action: () => Promise) => Promise;\n\tonChannelRenamed?: (channel: ChannelRecord) => void;\n\tonDocumentPersisted?: (target: Plan.DocumentTarget) => void;\n};\n\nconst BEARER = new RegExp(\"^Bearer ([A-Za-z0-9._~+/-]+=*)$\", \"i\");\n\ntype Document = {\n\tid: string;\n\ttitle: string;\n\tdescription?: string;\n\tcreation?: Plan.CreationMetadata;\n\tsource: string;\n\trevision: number;\n\tarchivedAt?: Date;\n\turl?: string;\n};\n\ntype PublicDocument = Omit & {\n\tbrief?: Plan.CreationMetadata[\"brief\"];\n\tarchivedAt?: string;\n};\n\nfunction summary(channel: ChannelRecord): DocumentSummary {\n\treturn {\n\t\tid: channel.id,\n\t\ttitle: channel.title,\n\t\t...(channel.description ? { description: channel.description.value } : {}),\n\t\t...(channel.archivedAt ? { archivedAt: channel.archivedAt.toISOString() } : {}),\n\t};\n}\n\n/** Strip durable idempotency and repository provenance from MCP responses. */\nfunction document(value: Document & { url: string }): PublicDocument & { url: string };\nfunction document(value: Document): PublicDocument;\nfunction document(value: Document): PublicDocument & { url?: string } {\n\treturn {\n\t\tid: value.id,\n\t\ttitle: value.title,\n\t\t...(value.description ? { description: value.description } : {}),\n\t\t...(value.creation ? { brief: value.creation.brief } : {}),\n\t\tsource: value.source,\n\t\trevision: value.revision,\n\t\t...(value.archivedAt ? { archivedAt: value.archivedAt.toISOString() } : {}),\n\t\t...(value.url ? { url: value.url } : {}),\n\t};\n}\n\nfunction exposed(\n\tchannel: ChannelRecord,\n\tstate: Awaited>,\n): Implementation | undefined {\n\tlet version = state.graph?.versions.at(-1);\n\tif (\n\t\t!state.creation\n\t\t|| !version\n\t\t|| (version.state !== \"approved\" && version.state !== \"locked\")\n\t) {\n\t\treturn undefined;\n\t}\n\tlet lifecycle = state.graph && state.lifecycle\n\t\t? implementationLifecycle({\n\t\t\tgraph: state.graph,\n\t\t\texecution: state.execution,\n\t\t\tlifecycle: state.lifecycle,\n\t\t})\n\t\t: undefined;\n\treturn {\n\t\tdocument: document({\n\t\t\tid: channel.id,\n\t\t\ttitle: channel.title,\n\t\t\t...(channel.description ? { description: channel.description.value } : {}),\n\t\t\tcreation: state.creation,\n\t\t\tsource: state.source,\n\t\t\trevision: state.revision,\n\t\t\tarchivedAt: channel.archivedAt,\n\t\t}),\n\t\trepository: {\n\t\t\tname: state.creation.origin.repository,\n\t\t\tbaseBranch: state.creation.origin.baseBranch,\n\t\t\tbaseCommit: state.creation.origin.baseCommit,\n\t\t},\n\t\tgraph: version,\n\t\texecution: state.execution\n\t\t\t? { state: \"active\", run: state.execution }\n\t\t\t: { state: \"idle\" },\n\t\tactivity: lifecycle?.activity,\n\t\thistory: lifecycle?.history ?? [],\n\t};\n}\n\nfunction claimResult(value: ClaimResult) {\n\treturn value.kind === \"started\"\n\t\t? { kind: \"started\" as const, run: value.run }\n\t\t: value;\n}\n\n/** Bind the backend-neutral MCP surface to hosted GitHub authentication. */\nexport function hosted(\n\tauth: HostedAuth,\n\tpersistence?: ImplementationPersistence,\n\tcallbacks: HostedCallbacks = {},\n): McpOptions {\n\tasync function directRepository(caller: HostedCaller, owner: string, name: string) {\n\t\ttry {\n\t\t\treturn await auth.github.repository(caller.oauthToken, owner, name);\n\t\t} catch (err) {\n\t\t\tif (err instanceof GitHubError && (err.status === 403 || err.status === 404)) {\n\t\t\t\treturn undefined;\n\t\t\t}\n\t\t\tthrow err;\n\t\t}\n\t}\n\n\tasync function locatedChannel(caller: HostedCaller, locator: string) {\n\t\tlet path: URL | undefined;\n\t\ttry {\n\t\t\tpath = new URL(locator, auth.config.origin);\n\t\t} catch {\n\t\t\tpath = undefined;\n\t\t}\n\t\tlet parsed = path?.origin === auth.config.origin\n\t\t\t? parseDocumentPath(path.pathname)\n\t\t\t: undefined;\n\t\tif (parsed?.slug) {\n\t\t\tlet repository = await directRepository(caller, parsed.owner, parsed.repository);\n\t\t\tif (!repository?.permissions.pull) return \"forbidden\" as const;\n\t\t\tlet channel = await auth.storage.channels.resolve(\n\t\t\t\trepository.id,\n\t\t\t\tdocumentSlug(parsed.slug),\n\t\t\t);\n\t\t\treturn channel ? { channel, repository } : undefined;\n\t\t}\n\n\t\tlet legacy = path?.origin === auth.config.origin\n\t\t\t? /^\\/channels\\/([0-9a-f-]{36})\\/?$/i.exec(path.pathname)\n\t\t\t: undefined;\n\t\tlet id = legacy?.[1]?.toLowerCase();\n\t\tlet channel = await auth.storage.channels.get(id && isChannelId(id) ? id : locator);\n\t\tif (!channel) return undefined;\n\t\tlet repository = await directRepository(\n\t\t\tcaller,\n\t\t\tchannel.repositoryOwner,\n\t\t\tchannel.repositoryName,\n\t\t);\n\t\tif (!repository?.permissions.pull || repository.id !== channel.repositoryId) {\n\t\t\treturn \"forbidden\" as const;\n\t\t}\n\t\treturn { channel, repository };\n\t}\n\n\tasync function writableChannel(caller: HostedCaller, locator: string) {\n\t\tlet located = await locatedChannel(caller, locator);\n\t\tif (!located || located === \"forbidden\") return { kind: \"unavailable\" as const };\n\t\tif (callbacks.isChannelDeleting?.(located.channel.id)) {\n\t\t\treturn { kind: \"unavailable\" as const };\n\t\t}\n\t\tif (!located.repository.permissions.push && !located.repository.permissions.admin) {\n\t\t\treturn { kind: \"forbidden\" as const };\n\t\t}\n\t\treturn { kind: \"allowed\" as const, ...located };\n\t}\n\n\tfunction run(caller: HostedCaller, input: ImplementationInput): Run {\n\t\treturn {\n\t\t\tid: crypto.randomUUID(),\n\t\t\tuser: caller.user.login,\n\t\t\tclient: { name: input.client.name, version: input.client.version },\n\t\t\tsession: input.client.session,\n\t\t\tplanRevision: input.planRevision,\n\t\t\tgraphVersion: input.graphVersion,\n\t\t\tgraphRevision: input.graphRevision,\n\t\t\trepository: input.repository,\n\t\t\tbranch: input.branch,\n\t\t\tcommit: input.commit,\n\t\t\tstartedAt: auth.clock().toISOString(),\n\t\t};\n\t}\n\n\tfunction serializeDocument(channelId: string, action: () => Promise): Promise {\n\t\treturn callbacks.serializeDocument?.(channelId, action) ?? action();\n\t}\n\n\treturn {\n\t\tasync caller(request) {\n\t\t\tlet match = request.headers.get(\"authorization\")?.match(BEARER);\n\t\t\tif (!match) return undefined;\n\t\t\tlet oauthToken = match[1]!;\n\t\t\ttry {\n\t\t\t\treturn { oauthToken, user: await auth.admission.user(oauthToken) };\n\t\t\t} catch (err) {\n\t\t\t\tif (err instanceof GitHubError && err.status === 401) return undefined;\n\t\t\t\tthrow err;\n\t\t\t}\n\t\t},\n\t\tdocuments: {\n\t\t\tasync list(caller, repository, includeArchived = false) {\n\t\t\t\tlet parts = repository.split(\"/\");\n\t\t\t\tif (parts.length !== 2 || !parts[0] || !parts[1]) return \"forbidden\";\n\t\t\t\tlet resolved = await directRepository(caller, parts[0], parts[1]);\n\t\t\t\tif (!resolved?.permissions.pull) return \"forbidden\";\n\n\t\t\t\tlet documents = [];\n\t\t\t\tlet cursor;\n\t\t\t\tdo {\n\t\t\t\t\tlet page = await auth.storage.channels.scan(\n\t\t\t\t\t\tresolved.id,\n\t\t\t\t\t\t100,\n\t\t\t\t\t\tcursor,\n\t\t\t\t\t\tincludeArchived,\n\t\t\t\t\t);\n\t\t\t\t\tdocuments.push(...page.channels.map(summary));\n\t\t\t\t\tcursor = page.next;\n\t\t\t\t} while (cursor);\n\t\t\t\treturn documents;\n\t\t\t},\n\t\t\tasync read(caller, id) {\n\t\t\t\tlet located = await locatedChannel(caller, id);\n\t\t\t\tif (!located || located === \"forbidden\") return undefined;\n\t\t\t\tlet { channel } = located;\n\n\t\t\t\tlet live = Rooms.get(channel.id)?.plan;\n\t\t\t\tif (live) {\n\t\t\t\t\ttry {\n\t\t\t\t\t\treturn document({\n\t\t\t\t\t\t\tid: channel.id,\n\t\t\t\t\t\t\ttitle: channel.title,\n\t\t\t\t\t\t\t...(channel.description ? { description: channel.description.value } : {}),\n\t\t\t\t\t\t\tcreation: live.creation,\n\t\t\t\t\t\t\tsource: Plan.source(live),\n\t\t\t\t\t\t\trevision: live.revision,\n\t\t\t\t\t\t\tarchivedAt: channel.archivedAt,\n\t\t\t\t\t\t});\n\t\t\t\t\t} catch {\n\t\t\t\t\t\treturn undefined;\n\t\t\t\t\t}\n\t\t\t\t}\n\n\t\t\t\tlet stored = await auth.storage.collaboration.load(channel.id, auth.clock());\n\t\t\t\tif (\n\t\t\t\t\t!stored\n\t\t\t\t\t|| stored.channel.id !== channel.id\n\t\t\t\t\t|| stored.channel.repositoryId !== channel.repositoryId\n\t\t\t\t\t|| stored.channel.repositoryOwner !== channel.repositoryOwner\n\t\t\t\t\t|| stored.channel.repositoryName !== channel.repositoryName\n\t\t\t\t) return undefined;\n\t\t\t\ttry {\n\t\t\t\t\tlet projected = await Plan.readStored(stored);\n\t\t\t\t\treturn document({\n\t\t\t\t\t\tid: channel.id,\n\t\t\t\t\t\ttitle: channel.title,\n\t\t\t\t\t\t...(channel.description ? { description: channel.description.value } : {}),\n\t\t\t\t\t\tcreation: projected.creation,\n\t\t\t\t\t\tsource: projected.source,\n\t\t\t\t\t\trevision: projected.revision,\n\t\t\t\t\t\tarchivedAt: channel.archivedAt,\n\t\t\t\t\t});\n\t\t\t\t} catch {\n\t\t\t\t\treturn undefined;\n\t\t\t\t}\n\t\t\t},\n\t\t},\n\t\trename: {\n\t\t\tasync rename(caller, input: RenameDocumentInput) {\n\t\t\t\tlet access = await writableChannel(caller, input.id);\n\t\t\t\tif (access.kind === \"unavailable\") return access;\n\t\t\t\tif (access.kind === \"forbidden\") {\n\t\t\t\t\treturn { kind: \"forbidden\" as const };\n\t\t\t\t}\n\t\t\t\tif (access.channel.archivedAt) return { kind: \"archived\" as const };\n\t\t\t\ttry {\n\t\t\t\t\tlet result = await auth.storage.channels.rename({\n\t\t\t\t\t\tid: access.channel.id,\n\t\t\t\t\t\ttitle: input.title,\n\t\t\t\t\t\tnow: auth.clock(),\n\t\t\t\t\t});\n\t\t\t\t\tif (result.changed) callbacks.onChannelRenamed?.(result.channel);\n\t\t\t\t\treturn {\n\t\t\t\t\t\tkind: result.changed ? \"renamed\" as const : \"unchanged\" as const,\n\t\t\t\t\t\tdocument: summary(result.channel),\n\t\t\t\t\t};\n\t\t\t\t} catch (err) {\n\t\t\t\t\tif (err instanceof StorageError && err.failure === \"conflict\") {\n\t\t\t\t\t\tlet current = await auth.storage.channels.get(input.id);\n\t\t\t\t\t\tif (!current || callbacks.isChannelDeleting?.(input.id)) {\n\t\t\t\t\t\t\treturn { kind: \"unavailable\" as const };\n\t\t\t\t\t\t}\n\t\t\t\t\t\tif (current.archivedAt) return { kind: \"archived\" as const };\n\t\t\t\t\t\treturn { kind: \"conflict\" as const };\n\t\t\t\t\t}\n\t\t\t\t\tif (err instanceof StorageError && err.failure === \"missing\") {\n\t\t\t\t\t\treturn { kind: \"unavailable\" as const };\n\t\t\t\t\t}\n\t\t\t\t\tthrow err;\n\t\t\t\t}\n\t\t\t},\n\t\t},\n\t\tarchive: {\n\t\t\tasync archive(caller, id) {\n\t\t\t\tlet access = await writableChannel(caller, id);\n\t\t\t\tif (access.kind !== \"allowed\") return access;\n\t\t\t\ttry {\n\t\t\t\t\tlet now = auth.clock();\n\t\t\t\t\tlet result = callbacks.archiveChannel\n\t\t\t\t\t\t? await callbacks.archiveChannel(access.channel.id, now)\n\t\t\t\t\t\t: await auth.storage.channels.archive({ id: access.channel.id, now });\n\t\t\t\t\tif (!result.channel.archivedAt) {\n\t\t\t\t\t\tthrow new Error(\"archiving a document returned active metadata\");\n\t\t\t\t\t}\n\t\t\t\t\treturn {\n\t\t\t\t\t\tkind: result.changed ? \"archived\" as const : \"unchanged\" as const,\n\t\t\t\t\t\tdocument: summary(result.channel),\n\t\t\t\t\t};\n\t\t\t\t} catch (err) {\n\t\t\t\t\tif (err instanceof StorageError && err.failure === \"missing\") {\n\t\t\t\t\t\treturn { kind: \"unavailable\" as const };\n\t\t\t\t\t}\n\t\t\t\t\tthrow err;\n\t\t\t\t}\n\t\t\t},\n\t\t},\n\t\trestore: {\n\t\t\tasync restore(caller, id) {\n\t\t\t\tlet access = await writableChannel(caller, id);\n\t\t\t\tif (access.kind !== \"allowed\") return access;\n\t\t\t\ttry {\n\t\t\t\t\tlet now = auth.clock();\n\t\t\t\t\tlet result = callbacks.restoreChannel\n\t\t\t\t\t\t? await callbacks.restoreChannel(access.channel.id, now)\n\t\t\t\t\t\t: await auth.storage.channels.restore({ id: access.channel.id, now });\n\t\t\t\t\tif (result.channel.archivedAt) {\n\t\t\t\t\t\tthrow new Error(\"restoring a document returned archived metadata\");\n\t\t\t\t\t}\n\t\t\t\t\treturn {\n\t\t\t\t\t\tkind: result.changed ? \"restored\" as const : \"unchanged\" as const,\n\t\t\t\t\t\tdocument: summary(result.channel),\n\t\t\t\t\t};\n\t\t\t\t} catch (err) {\n\t\t\t\t\tif (err instanceof StorageError && err.failure === \"missing\") {\n\t\t\t\t\t\treturn { kind: \"unavailable\" as const };\n\t\t\t\t\t}\n\t\t\t\t\tthrow err;\n\t\t\t\t}\n\t\t\t},\n\t\t},\n\t\tcreate: {\n\t\t\tasync create(caller, input) {\n\t\t\t\tlet parts = input.repository.split(\"/\");\n\t\t\t\tif (parts.length !== 2 || !parts[0] || !parts[1]) return { kind: \"forbidden\" };\n\t\t\t\tlet repository = await directRepository(caller, parts[0], parts[1]);\n\t\t\t\tif (!repository || (!repository.permissions.push && !repository.permissions.admin)) {\n\t\t\t\t\treturn { kind: \"forbidden\" };\n\t\t\t\t}\n\t\t\t\tlet id = deterministicChannelId(repository.id, input.idempotencyKey);\n\t\t\t\tif (callbacks.isChannelDeleting?.(id)) return { kind: \"unavailable\" };\n\t\t\t\tawait auth.storage.users.put({\n\t\t\t\t\tid: caller.user.id,\n\t\t\t\t\tlogin: caller.user.login,\n\t\t\t\t\tavatarUrl: caller.user.avatarUrl,\n\t\t\t\t\tnow: auth.clock(),\n\t\t\t\t});\n\t\t\t\tlet { brief, plan, ...origin } = input;\n\t\t\t\tlet creation: Plan.CreationMetadata = { brief, origin };\n\t\t\t\tlet initial = await Plan.initial(plan, creation);\n\t\t\t\tlet created: ChannelRecord;\n\t\t\t\ttry {\n\t\t\t\t\tcreated = await auth.storage.channels.create({\n\t\t\t\t\t\tid,\n\t\t\t\t\t\trepositoryId: repository.id,\n\t\t\t\t\t\trepositoryOwner: repository.owner,\n\t\t\t\t\t\trepositoryName: repository.name,\n\t\t\t\t\t\ttitle: input.title,\n\t\t\t\t\t\tcreatedBy: caller.user.id,\n\t\t\t\t\t\tnow: auth.clock(),\n\t\t\t\t\t\tinitial,\n\t\t\t\t\t});\n\t\t\t\t} catch (err) {\n\t\t\t\t\tif (!(err instanceof StorageError) || err.failure !== \"conflict\") throw err;\n\t\t\t\t\tif (callbacks.isChannelDeleting?.(id)) return { kind: \"unavailable\" };\n\t\t\t\t\tlet stored = await auth.storage.collaboration.load(id, auth.clock());\n\t\t\t\t\tif (!stored || stored.channel.repositoryId !== repository.id) {\n\t\t\t\t\t\treturn { kind: \"conflict\" };\n\t\t\t\t\t}\n\t\t\t\t\tlet restored = await Plan.readStored(stored);\n\t\t\t\t\tif (\n\t\t\t\t\t\t!restored.creation\n\t\t\t\t\t\t|| restored.creation.origin.idempotencyKey !== input.idempotencyKey\n\t\t\t\t\t\t|| restored.creation.origin.fingerprint !== input.fingerprint\n\t\t\t\t\t) return { kind: \"conflict\" };\n\t\t\t\t\tcallbacks.onDocumentPersisted?.({\n\t\t\t\t\t\tchannelId: id,\n\t\t\t\t\t\trevision: restored.revision,\n\t\t\t\t\t\tsource: restored.source,\n\t\t\t\t\t\tsourceHash: Plan.sourceHash(restored.source),\n\t\t\t\t\t});\n\t\t\t\t\treturn {\n\t\t\t\t\t\tkind: \"replayed\",\n\t\t\t\t\t\tdocument: document({\n\t\t\t\t\t\t\tid,\n\t\t\t\t\t\t\ttitle: stored.channel.title,\n\t\t\t\t\t\t\t...(stored.channel.description\n\t\t\t\t\t\t\t\t? { description: stored.channel.description.value }\n\t\t\t\t\t\t\t\t: {}),\n\t\t\t\t\t\t\tcreation: restored.creation,\n\t\t\t\t\t\t\tsource: restored.source,\n\t\t\t\t\t\t\trevision: restored.revision,\n\t\t\t\t\t\t\tarchivedAt: stored.channel.archivedAt,\n\t\t\t\t\t\t\turl: documentPath(\n\t\t\t\t\t\t\t\trepository.owner,\n\t\t\t\t\t\t\t\trepository.name,\n\t\t\t\t\t\t\t\tstored.channel.slug,\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}\n\t\t\t\tcallbacks.onDocumentPersisted?.({\n\t\t\t\t\tchannelId: id,\n\t\t\t\t\trevision: 0,\n\t\t\t\t\tsource: initial.source,\n\t\t\t\t\tsourceHash: initial.sourceHash,\n\t\t\t\t});\n\t\t\t\treturn {\n\t\t\t\t\tkind: \"created\",\n\t\t\t\t\tdocument: document({\n\t\t\t\t\t\tid,\n\t\t\t\t\t\ttitle: created.title,\n\t\t\t\t\t\t...(created.description ? { description: created.description.value } : {}),\n\t\t\t\t\t\tcreation,\n\t\t\t\t\t\tsource: initial.source,\n\t\t\t\t\t\trevision: 0,\n\t\t\t\t\t\turl: documentPath(repository.owner, repository.name, created.slug),\n\t\t\t\t\t}),\n\t\t\t\t};\n\t\t\t},\n\t\t},\n\t\t...(persistence\n\t\t\t? {\n\t\t\t\timplementations: {\n\t\t\t\t\tasync readImplementation(caller: HostedCaller, id: string) {\n\t\t\t\t\t\tlet located = await locatedChannel(caller, id);\n\t\t\t\t\t\tif (located === \"forbidden\") return \"forbidden\" as const;\n\t\t\t\t\t\tif (!located) return undefined;\n\t\t\t\t\t\tlet { channel } = located;\n\t\t\t\t\t\tlet live = Rooms.get(channel.id)?.plan;\n\t\t\t\t\t\tif (live) {\n\t\t\t\t\t\t\treturn exposed(channel, {\n\t\t\t\t\t\t\t\tsource: Plan.source(live),\n\t\t\t\t\t\t\t\trevision: live.revision,\n\t\t\t\t\t\t\t\t...(live.creation ? { creation: live.creation } : {}),\n\t\t\t\t\t\t\t\t...(live.graph ? { graph: live.graph } : {}),\n\t\t\t\t\t\t\t\t...(live.execution ? { execution: live.execution } : {}),\n\t\t\t\t\t\t\t\tlifecycle: live.lifecycle,\n\t\t\t\t\t\t\t});\n\t\t\t\t\t\t}\n\t\t\t\t\t\tlet stored = await auth.storage.collaboration.load(channel.id, auth.clock());\n\t\t\t\t\t\treturn stored ? exposed(channel, await Plan.readStored(stored)) : undefined;\n\t\t\t\t\t},\n\t\t\t\t\tasync startImplementation(caller: HostedCaller, input: ImplementationInput) {\n\t\t\t\t\t\treturn serializeDocument(input.id, async () => {\n\t\t\t\t\t\t\tlet access = await writableChannel(caller, input.id);\n\t\t\t\t\t\t\tif (access.kind !== \"allowed\") return access;\n\t\t\t\t\t\t\tlet channel = access.channel;\n\t\t\t\t\t\t\tif (`${channel.repositoryOwner}/${channel.repositoryName}` !== input.repository) {\n\t\t\t\t\t\t\t\treturn { kind: \"forbidden\" as const };\n\t\t\t\t\t\t\t}\n\t\t\t\t\t\t\tif (channel.archivedAt) {\n\t\t\t\t\t\t\t\treturn { kind: \"refused\" as const, reason: \"document-archived\" };\n\t\t\t\t\t\t\t}\n\t\t\t\t\t\t\tlet claimRun = run(caller, input);\n\t\t\t\t\t\t\tlet live = Rooms.get(input.id)?.plan;\n\t\t\t\t\t\t\tif (live) {\n\t\t\t\t\t\t\t\treturn claimResult(\n\t\t\t\t\t\t\t\t\tawait claimImplementation(live, {\n\t\t\t\t\t\t\t\t\t\tplanRevision: input.planRevision,\n\t\t\t\t\t\t\t\t\t\tgraphRevision: input.graphRevision,\n\t\t\t\t\t\t\t\t\t\trun: claimRun,\n\t\t\t\t\t\t\t\t\t}),\n\t\t\t\t\t\t\t\t);\n\t\t\t\t\t\t\t}\n\t\t\t\t\t\t\tfor (let attempt = 0; attempt < 2; attempt++) {\n\t\t\t\t\t\t\t\tif (callbacks.isChannelDeleting?.(input.id)) {\n\t\t\t\t\t\t\t\t\treturn { kind: \"unavailable\" as const };\n\t\t\t\t\t\t\t\t}\n\t\t\t\t\t\t\t\tlet stored = await auth.storage.collaboration.load(input.id, auth.clock());\n\t\t\t\t\t\t\t\tif (!stored) return { kind: \"unavailable\" as const };\n\t\t\t\t\t\t\t\tif (stored.channel.archivedAt) {\n\t\t\t\t\t\t\t\t\treturn { kind: \"refused\" as const, reason: \"document-archived\" };\n\t\t\t\t\t\t\t\t}\n\t\t\t\t\t\t\t\tif (!stored.snapshot) return { kind: \"refused\" as const, reason: \"missing\" };\n\t\t\t\t\t\t\t\tlet prepared = Plan.claimStored(stored, {\n\t\t\t\t\t\t\t\t\tplanRevision: input.planRevision,\n\t\t\t\t\t\t\t\t\tgraphRevision: input.graphRevision,\n\t\t\t\t\t\t\t\t\trun: claimRun,\n\t\t\t\t\t\t\t\t});\n\t\t\t\t\t\t\t\tif (prepared.result.kind !== \"started\" || !prepared.sidecar) {\n\t\t\t\t\t\t\t\t\treturn claimResult(prepared.result);\n\t\t\t\t\t\t\t\t}\n\t\t\t\t\t\t\t\ttry {\n\t\t\t\t\t\t\t\t\tawait auth.storage.collaboration.commit({\n\t\t\t\t\t\t\t\t\t\tchannelId: input.id,\n\t\t\t\t\t\t\t\t\t\tlease: persistence.lease(),\n\t\t\t\t\t\t\t\t\t\texpectedRevision: stored.channel.revision,\n\t\t\t\t\t\t\t\t\t\toperationId: `implementation:${claimRun.id}`,\n\t\t\t\t\t\t\t\t\t\tepoch: stored.snapshot.epoch,\n\t\t\t\t\t\t\t\t\t\tsidecar: prepared.sidecar,\n\t\t\t\t\t\t\t\t\t\tevents: [],\n\t\t\t\t\t\t\t\t\t\tnow: auth.clock(),\n\t\t\t\t\t\t\t\t\t});\n\t\t\t\t\t\t\t\t\treturn claimResult(prepared.result);\n\t\t\t\t\t\t\t\t} catch (err) {\n\t\t\t\t\t\t\t\t\tif (err instanceof StorageError && err.failure === \"missing\") {\n\t\t\t\t\t\t\t\t\t\treturn { kind: \"unavailable\" as const };\n\t\t\t\t\t\t\t\t\t}\n\t\t\t\t\t\t\t\t\tif (!(err instanceof StorageError) || err.failure !== \"conflict\") throw err;\n\t\t\t\t\t\t\t\t}\n\t\t\t\t\t\t\t}\n\t\t\t\t\t\t\treturn { kind: \"refused\" as const, reason: \"conflict\" };\n\t\t\t\t\t\t});\n\t\t\t\t\t},\n\t\t\t\t\tasync reportLifecycle(caller: HostedCaller, input: LifecycleArguments) {\n\t\t\t\t\t\treturn serializeDocument(input.id, async () => {\n\t\t\t\t\t\t\tlet access = await writableChannel(caller, input.id);\n\t\t\t\t\t\t\tif (access.kind !== \"allowed\") return access;\n\t\t\t\t\t\t\tlet { id: _id, ...event } = input;\n\t\t\t\t\t\t\tlet live = Rooms.get(input.id)?.plan;\n\t\t\t\t\t\t\tif (live) {\n\t\t\t\t\t\t\t\tlet result = await reportImplementationLifecycle(live, event);\n\t\t\t\t\t\t\t\tif (result.kind === \"refused\") return result;\n\t\t\t\t\t\t\t\treturn {\n\t\t\t\t\t\t\t\t\tkind: result.kind,\n\t\t\t\t\t\t\t\t\tlifecycle: implementationLifecycle({\n\t\t\t\t\t\t\t\t\t\tgraph: result.state.graph,\n\t\t\t\t\t\t\t\t\t\texecution: result.state.execution,\n\t\t\t\t\t\t\t\t\t\tlifecycle: result.state.lifecycle,\n\t\t\t\t\t\t\t\t\t}),\n\t\t\t\t\t\t\t\t};\n\t\t\t\t\t\t\t}\n\t\t\t\t\t\t\tfor (let attempt = 0; attempt < 2; attempt++) {\n\t\t\t\t\t\t\t\tif (callbacks.isChannelDeleting?.(input.id)) {\n\t\t\t\t\t\t\t\t\treturn { kind: \"unavailable\" as const };\n\t\t\t\t\t\t\t\t}\n\t\t\t\t\t\t\t\tlet stored = await auth.storage.collaboration.load(input.id, auth.clock());\n\t\t\t\t\t\t\t\tif (!stored) return { kind: \"unavailable\" as const };\n\t\t\t\t\t\t\t\tif (!stored.snapshot) return { kind: \"refused\" as const, reason: \"inactive\" };\n\t\t\t\t\t\t\t\tlet prepared = Plan.lifecycleStored(stored, event);\n\t\t\t\t\t\t\t\tif (prepared.result.kind === \"refused\") return prepared.result;\n\t\t\t\t\t\t\t\tif (prepared.result.kind === \"replayed\") {\n\t\t\t\t\t\t\t\t\treturn {\n\t\t\t\t\t\t\t\t\t\tkind: \"replayed\" as const,\n\t\t\t\t\t\t\t\t\t\tlifecycle: implementationLifecycle({\n\t\t\t\t\t\t\t\t\t\t\tgraph: prepared.result.state.graph,\n\t\t\t\t\t\t\t\t\t\t\texecution: prepared.result.state.execution,\n\t\t\t\t\t\t\t\t\t\t\tlifecycle: prepared.result.state.lifecycle,\n\t\t\t\t\t\t\t\t\t\t}),\n\t\t\t\t\t\t\t\t\t};\n\t\t\t\t\t\t\t\t}\n\t\t\t\t\t\t\t\tif (!prepared.sidecar) return { kind: \"refused\" as const, reason: \"inactive\" };\n\t\t\t\t\t\t\t\ttry {\n\t\t\t\t\t\t\t\t\tawait auth.storage.collaboration.commit({\n\t\t\t\t\t\t\t\t\t\tchannelId: input.id,\n\t\t\t\t\t\t\t\t\t\tlease: persistence.lease(),\n\t\t\t\t\t\t\t\t\t\texpectedRevision: stored.channel.revision,\n\t\t\t\t\t\t\t\t\t\toperationId: `lifecycle:${input.idempotencyKey}`,\n\t\t\t\t\t\t\t\t\t\tepoch: stored.snapshot.epoch,\n\t\t\t\t\t\t\t\t\t\tsidecar: prepared.sidecar,\n\t\t\t\t\t\t\t\t\t\tevents: [],\n\t\t\t\t\t\t\t\t\t\tnow: auth.clock(),\n\t\t\t\t\t\t\t\t\t\tallowArchived: true,\n\t\t\t\t\t\t\t\t\t});\n\t\t\t\t\t\t\t\t\treturn {\n\t\t\t\t\t\t\t\t\t\tkind: \"accepted\" as const,\n\t\t\t\t\t\t\t\t\t\tlifecycle: implementationLifecycle({\n\t\t\t\t\t\t\t\t\t\t\tgraph: prepared.result.state.graph,\n\t\t\t\t\t\t\t\t\t\t\texecution: prepared.result.state.execution,\n\t\t\t\t\t\t\t\t\t\t\tlifecycle: prepared.result.state.lifecycle,\n\t\t\t\t\t\t\t\t\t\t}),\n\t\t\t\t\t\t\t\t\t};\n\t\t\t\t\t\t\t\t} catch (err) {\n\t\t\t\t\t\t\t\t\tif (err instanceof StorageError && err.failure === \"missing\") {\n\t\t\t\t\t\t\t\t\t\treturn { kind: \"unavailable\" as const };\n\t\t\t\t\t\t\t\t\t}\n\t\t\t\t\t\t\t\t\tif (!(err instanceof StorageError) || err.failure !== \"conflict\") throw err;\n\t\t\t\t\t\t\t\t}\n\t\t\t\t\t\t\t}\n\t\t\t\t\t\t\treturn { kind: \"refused\" as const, reason: \"conflict\" };\n\t\t\t\t\t\t});\n\t\t\t\t\t},\n\t\t\t\t},\n\t\t\t}\n\t\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",{"_54":55,"_139":140,"_141":142,"_143":144,"_145":146,"_147":148,"_149":150},"sources",[],"viewer","meta",{"_131":132,"_133":134,"_135":136,"_42":31,"_137":126,"_138":31,"_48":49,"_50":49},"branches",[73,74,75,76,77,78,79,80,81,82,83,84,85,86,87,88,89,90,91,92,93,94,95,96,97,98,99,100,101,102,103,104,105,106,107,108,109,110,111,112,113,114,115,116,117,118,119,120,121,122,123,124,125,126,127,128,129,130],"tags",[69,70,71,72],"cloneUrl","https://git.nexthub.sh/githubnext/chopin.git","color-controls-slice-1","color-controls-slice-2","color-controls-slice-3","color-controls-slice-4","Krzysztof-Cieslak-patch-1","Krzysztof-Cieslak-patch-2","Maggie/app-preview-toolkit","Maggie/ci-playwright-install-timeout","Maggie/collaborative-visual-decision","Maggie/design-audit","Maggie/generic-visual-decision-runtime","Maggie/impeccable-chopin-metadata","Maggie/jev-chat-product","Maggie/jev-composed-assessment","Maggie/native-document-layouts","Maggie/openui-composition-product","Maggie/openui-composition-trial","Maggie/planner-visual-authoring","Maggie/planner-visual-requests","Maggie/visual-selection-eval","artifacts/pr-419-live-preview-20261009","automation/pr-maintenance-state","automation/use-effect/callout-disabled-picker-8cf9e49ba5c09471","automation/use-effect/collaboration-options-ref-4e3a5a08a879a5ae","automation/use-effect/room-workspace-effective-access-a57d40866c71bed0","chore/bun-1.4.2","color-controls","color-controls-plan","comments","design-pr-assets","design/archived-decisions-badge","design/channel-route-remount","design/chat-decision-entry","design/conversation-analysis-markers","design/decision-evidence","design/settled-line-icon","dev/integration","diagram-step-controls","feat/liveapp-frontend-pilot","feat/local-experiments","feat/local-launcher-tracer","fix/autolink-mdx-crash","github-pills/2-pills","github-pills/3-hover-card","maggie/app-preview-toolkit","maggie/ci-playwright-install-timeout","maggie/collaborative-visual-decision","maggie/design-audit","maggie/generic-visual-decision-runtime","maggie/impeccable-chopin-metadata","maggie/jev-composed-assessment","maggie/native-document-layouts","maggie/openui-composition-product","maggie/openui-composition-trial","maggie/planner-visual-authoring","maggie/planner-visual-requests","maggie/visual-selection-eval","main","plain-text-fence-chrome","tokens/09-copy","wireframes/2-renderer","wireframes/3-planner","description","Let's compose rich plans together","owner","githubnext","section","","head","empty","pins",[165,166,167],"documents",{"_160":161,"_162":163},"code",{"_156":157,"_158":159},"automations",{"_153":154,"_155":-5},"delivery",{"_151":49,"_152":-5},"tag","04zvKQ8QOrDUF8TO1Ovz0Zy8_TT","releases","applications","workflows",3,"deployments","commits",1000,"changes",13,"counts",{"_164":163},"total",11,"issue",{"_168":158,"_170":181,"_15":158,"_172":182,"_52":174,"_175":31,"_176":174,"_177":159},{"_168":178,"_170":179,"_15":178,"_172":180,"_52":174,"_175":31,"_176":174,"_177":49},{"_168":169,"_170":171,"_15":169,"_172":173,"_52":174,"_175":31,"_176":174,"_177":163},"id","issues","name","Issues","filters",{},true,"saved","pinnable","count","tasks","Tasks",{},"Changes",{},{"_168":158,"_170":181,"_15":158,"_172":226,"_52":174,"_175":31,"_176":174},{"_168":178,"_170":179,"_15":178,"_172":225,"_52":174,"_175":31,"_176":174},{"_168":169,"_170":171,"_15":169,"_172":224,"_52":174,"_175":31,"_176":174},{"_168":221,"_170":222,"_15":221,"_172":223,"_52":31,"_175":31,"_176":174},{"_168":218,"_170":219,"_15":218,"_172":220,"_52":31,"_175":31,"_176":174},{"_168":153,"_170":216,"_15":145,"_172":217,"_52":31,"_175":31,"_176":174},{"_168":155,"_170":213,"_15":214,"_172":215,"_52":31,"_175":31,"_176":174},{"_168":151,"_170":211,"_15":151,"_172":212,"_52":31,"_175":31,"_176":174},{"_168":207,"_170":208,"_15":209,"_172":210,"_52":31,"_175":31,"_176":174},{"_168":141,"_170":205,"_15":141,"_172":206,"_52":31,"_175":31,"_176":31},{"_168":202,"_170":203,"_15":202,"_172":204,"_52":31,"_175":31,"_176":31},{"_168":199,"_170":200,"_15":199,"_172":201,"_52":31,"_175":31,"_176":31},{"_168":196,"_170":197,"_15":196,"_172":198,"_52":31,"_175":31,"_176":31},"decisions","Decisions",{},"changelog","Changelog",{},"roadmap","Roadmap",{},"Documents",{},"activity","Activity","insights",{},"Releases",{},"Deployments","automations/deployments",{},"Workflows",{},"discussions","Discussions",{},"goals","Goals",{},{},{},{},"groups","user","agents",[],"now",1794508252872,"sidebar","expanded"]