[{"_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","cf5be46785a9f6a748cc19f83165ac5c19340a2c","path","apps/server/src/mcp.ts","oid","31ec2f333af44f2d318ab2b00d8a97356d154a32","size",27349,"commit","mounts",[],"source","plain",{"_13":14,"_15":16},"kind","text","/**\n * Backend-neutral MCP document protocol.\n *\n * Hosts authenticate callers and resolve repository-scoped documents. This\n * module only validates and presents their results through MCP.\n */\n\nimport {\n\tBRIEF,\n\tisRepository,\n\tMAX_REQUEST_BYTES,\n\tMAX_TITLE_LENGTH,\n\tprepare,\n\tREPOSITORY_PATH_PATTERN,\n} from \"./mcp/create\";\nimport { isLifecycleTool, LIFECYCLE_TOOLS, lifecycleCall } from \"./mcp/lifecycle\";\nimport { normalizedTitle } from \"./channels/title\";\n\nimport type { Brief, CreateDocumentInput } from \"./mcp/create\";\nimport type { Run, Version } from \"./tasks/graphs\";\nimport type { LifecycleArguments } from \"./mcp/lifecycle\";\nimport type { ImplementationLifecycle } from \"./tasks/lifecycle\";\n\nexport type { Brief, CreateDocumentInput, CreationOrigin } from \"./mcp/create\";\n\nexport type DocumentSummary = {\n\tid: string;\n\ttitle: string;\n\tdescription?: string;\n\tarchivedAt?: string;\n};\n\nexport type Document = DocumentSummary & {\n\tbrief?: Brief;\n\tsource: string;\n\trevision: number;\n};\n\nexport type DocumentReader = {\n\tlist(\n\t\tcaller: Caller,\n\t\trepository: string,\n\t\tincludeArchived?: boolean,\n\t): Promise;\n\tread(caller: Caller, id: string): Promise;\n};\n\nexport type CreatedDocument = Document & { url: string };\n\nexport type Implementation = {\n\tdocument: Document;\n\trepository: { name: string; baseBranch: string; baseCommit: string };\n\tgraph: Version;\n\texecution: { state: \"idle\" } | { state: \"active\"; run: Run };\n\tactivity?: ImplementationLifecycle[\"activity\"];\n\thistory: ImplementationLifecycle[\"history\"];\n};\n\nexport type ImplementationInput = {\n\tid: string;\n\tplanRevision: number;\n\tgraphVersion: number;\n\tgraphRevision: number;\n\trepository: string;\n\tbranch: string;\n\tcommit: string;\n\tclient: { name: string; version: string; session: string };\n};\n\nexport type Implementations = {\n\treadImplementation(caller: Caller, id: string): Promise;\n\tstartImplementation(\n\t\tcaller: Caller,\n\t\tinput: ImplementationInput,\n\t): Promise<\n\t\t| { kind: \"started\"; run: Run }\n\t\t| { kind: \"active\"; run: Run }\n\t\t| { kind: \"forbidden\" }\n\t\t| { kind: \"unavailable\" }\n\t\t| { kind: \"refused\"; reason: string }\n\t>;\n\treportLifecycle?(\n\t\tcaller: Caller,\n\t\tinput: LifecycleArguments,\n\t): Promise<\n\t\t| { kind: \"accepted\" | \"replayed\"; lifecycle: ImplementationLifecycle }\n\t\t| { kind: \"forbidden\" }\n\t\t| { kind: \"unavailable\" }\n\t\t| { kind: \"refused\"; reason: string }\n\t>;\n};\n\nexport type CreateDocument = {\n\tcreate(\n\t\tcaller: Caller,\n\t\tinput: CreateDocumentInput,\n\t): Promise<\n\t\t| { kind: \"created\"; document: CreatedDocument }\n\t\t| { kind: \"replayed\"; document: CreatedDocument }\n\t\t| { kind: \"conflict\" }\n\t\t| { kind: \"forbidden\" }\n\t\t| { kind: \"unavailable\" }\n\t>;\n};\n\nexport type RenameDocumentInput = {\n\tid: string;\n\ttitle: string;\n};\n\nexport type RenameDocument = {\n\trename(\n\t\tcaller: Caller,\n\t\tinput: RenameDocumentInput,\n\t): Promise<\n\t\t| { kind: \"renamed\" | \"unchanged\"; document: DocumentSummary }\n\t\t| { kind: \"archived\" | \"conflict\" | \"forbidden\" | \"unavailable\" }\n\t>;\n};\n\nexport type ArchiveDocument = {\n\tarchive(\n\t\tcaller: Caller,\n\t\tid: string,\n\t): Promise<\n\t\t| { kind: \"archived\" | \"unchanged\"; document: DocumentSummary }\n\t\t| { kind: \"forbidden\" | \"unavailable\" }\n\t>;\n};\n\nexport type RestoreDocument = {\n\trestore(\n\t\tcaller: Caller,\n\t\tid: string,\n\t): Promise<\n\t\t| { kind: \"restored\" | \"unchanged\"; document: DocumentSummary }\n\t\t| { kind: \"forbidden\" | \"unavailable\" }\n\t>;\n};\n\nexport type McpOptions = {\n\t/** The host owns authentication; MCP only receives its result. */\n\tcaller(request: Request): Promise | Caller | undefined;\n\tdocuments: DocumentReader;\n\tcreate?: CreateDocument;\n\trename?: RenameDocument;\n\tarchive?: ArchiveDocument;\n\trestore?: RestoreDocument;\n\timplementations?: Implementations;\n};\n\ntype Tool = {\n\tname: string;\n\tdescription: string;\n\tinputSchema: Record;\n\toutputSchema: Record;\n};\n\nconst MAX_DOCUMENT_ID_LENGTH = 128;\nconst MAX_DOCUMENT_LOCATOR_LENGTH = 2_048;\n\nconst DOCUMENT_IDENTITY = {\n\tid: { type: \"string\" },\n\ttitle: { type: \"string\" },\n\tdescription: { type: \"string\" },\n};\n\nconst ACTIVE_DOCUMENT = {\n\ttype: \"object\",\n\tproperties: DOCUMENT_IDENTITY,\n\trequired: [\"id\", \"title\"],\n\tadditionalProperties: false,\n};\n\nconst DOCUMENT = {\n\ttype: \"object\",\n\tproperties: {\n\t\t...DOCUMENT_IDENTITY,\n\t\tarchivedAt: { type: \"string\", format: \"date-time\" },\n\t},\n\trequired: [\"id\", \"title\"],\n\tadditionalProperties: false,\n};\n\nconst ARCHIVED_DOCUMENT = {\n\t...DOCUMENT,\n\trequired: [\"id\", \"title\", \"archivedAt\"],\n};\n\nfunction outcome(codes: string[]) {\n\treturn {\n\t\ttype: \"object\",\n\t\tproperties: { code: { type: \"string\", enum: codes } },\n\t\trequired: [\"code\"],\n\t\tadditionalProperties: false,\n\t};\n}\n\nconst IMPLEMENTATION = {\n\ttype: \"object\",\n\tproperties: {\n\t\tid: { type: \"string\", minLength: 1, maxLength: MAX_DOCUMENT_ID_LENGTH },\n\t\tplanRevision: { type: \"integer\", minimum: 0 },\n\t\tgraphVersion: { type: \"integer\", minimum: 1 },\n\t\tgraphRevision: { type: \"integer\", minimum: 1 },\n\t\trepository: { type: \"string\", pattern: REPOSITORY_PATH_PATTERN },\n\t\tbranch: { type: \"string\", minLength: 1, maxLength: 255 },\n\t\tcommit: { type: \"string\", minLength: 1, maxLength: 64 },\n\t},\n\trequired: [\n\t\t\"id\",\n\t\t\"planRevision\",\n\t\t\"graphVersion\",\n\t\t\"graphRevision\",\n\t\t\"repository\",\n\t\t\"branch\",\n\t\t\"commit\",\n\t],\n\tadditionalProperties: false,\n};\n\n/** The host can change readers, but never the public tool contract. */\nexport const TOOLS: Tool[] = [\n\t{\n\t\tname: \"list_documents\",\n\t\tdescription: \"List Chopin documents available in a repository.\",\n\t\tinputSchema: {\n\t\t\ttype: \"object\",\n\t\t\tproperties: {\n\t\t\t\trepository: { type: \"string\", pattern: REPOSITORY_PATH_PATTERN },\n\t\t\t\tincludeArchived: { type: \"boolean\", default: false },\n\t\t\t},\n\t\t\trequired: [\"repository\"],\n\t\t\tadditionalProperties: false,\n\t\t},\n\t\toutputSchema: {\n\t\t\ttype: \"object\",\n\t\t\tproperties: { documents: { type: \"array\", items: DOCUMENT } },\n\t\t\trequired: [\"documents\"],\n\t\t\tadditionalProperties: false,\n\t\t},\n\t},\n\t{\n\t\tname: \"read_document\",\n\t\tdescription: \"Read a Chopin document by ID or canonical URL.\",\n\t\tinputSchema: {\n\t\t\ttype: \"object\",\n\t\t\tproperties: {\n\t\t\t\tid: {\n\t\t\t\t\ttype: \"string\",\n\t\t\t\t\tminLength: 1,\n\t\t\t\t\tmaxLength: MAX_DOCUMENT_LOCATOR_LENGTH,\n\t\t\t\t\tpattern: \"\\\\S\",\n\t\t\t\t},\n\t\t\t},\n\t\t\trequired: [\"id\"],\n\t\t\tadditionalProperties: false,\n\t\t},\n\t\toutputSchema: {\n\t\t\ttype: \"object\",\n\t\t\tproperties: {\n\t\t\t\t...DOCUMENT.properties,\n\t\t\t\tbrief: BRIEF,\n\t\t\t\tsource: { type: \"string\" },\n\t\t\t\trevision: { type: \"integer\", minimum: 0 },\n\t\t\t},\n\t\t\trequired: [\"id\", \"title\", \"source\", \"revision\"],\n\t\t\tadditionalProperties: false,\n\t\t},\n\t},\n\t{\n\t\tname: \"create_document\",\n\t\tdescription: \"Create a Chopin document from a structured brief and canonical plan.\",\n\t\tinputSchema: {\n\t\t\ttype: \"object\",\n\t\t\tproperties: {\n\t\t\t\tidempotencyKey: { type: \"string\", minLength: 1, maxLength: 128 },\n\t\t\t\trepository: { type: \"string\", pattern: REPOSITORY_PATH_PATTERN },\n\t\t\t\tbaseBranch: { type: \"string\", minLength: 1, maxLength: 255 },\n\t\t\t\tbaseCommit: { type: \"string\", minLength: 1, maxLength: 64 },\n\t\t\t\ttitle: { type: \"string\", minLength: 1, maxLength: MAX_TITLE_LENGTH },\n\t\t\t\tbrief: BRIEF,\n\t\t\t\tplan: { type: \"string\", minLength: 1 },\n\t\t\t},\n\t\t\trequired: [\n\t\t\t\t\"idempotencyKey\",\n\t\t\t\t\"repository\",\n\t\t\t\t\"baseBranch\",\n\t\t\t\t\"baseCommit\",\n\t\t\t\t\"title\",\n\t\t\t\t\"brief\",\n\t\t\t\t\"plan\",\n\t\t\t],\n\t\t\tadditionalProperties: false,\n\t\t},\n\t\toutputSchema: {\n\t\t\ttype: \"object\",\n\t\t\tproperties: {\n\t\t\t\t...DOCUMENT.properties,\n\t\t\t\tbrief: BRIEF,\n\t\t\t\tsource: { type: \"string\" },\n\t\t\t\trevision: { type: \"integer\", minimum: 0 },\n\t\t\t\turl: { type: \"string\" },\n\t\t\t},\n\t\t\trequired: [\"id\", \"title\", \"brief\", \"source\", \"revision\", \"url\"],\n\t\t\tadditionalProperties: false,\n\t\t},\n\t},\n\t{\n\t\tname: \"rename_document\",\n\t\tdescription: \"Rename a Chopin document without changing its canonical plan or revision.\",\n\t\tinputSchema: {\n\t\t\ttype: \"object\",\n\t\t\tproperties: {\n\t\t\t\tid: {\n\t\t\t\t\ttype: \"string\",\n\t\t\t\t\tminLength: 1,\n\t\t\t\t\tmaxLength: MAX_DOCUMENT_ID_LENGTH,\n\t\t\t\t\tpattern: \"\\\\S\",\n\t\t\t\t},\n\t\t\t\ttitle: { type: \"string\", minLength: 1, maxLength: MAX_TITLE_LENGTH },\n\t\t\t},\n\t\t\trequired: [\"id\", \"title\"],\n\t\t\tadditionalProperties: false,\n\t\t},\n\t\toutputSchema: {\n\t\t\toneOf: [\n\t\t\t\tACTIVE_DOCUMENT,\n\t\t\t\toutcome([\n\t\t\t\t\t\"document-archived\",\n\t\t\t\t\t\"title-conflict\",\n\t\t\t\t\t\"repository-forbidden\",\n\t\t\t\t\t\"document-unavailable\",\n\t\t\t\t]),\n\t\t\t],\n\t\t},\n\t},\n\t{\n\t\tname: \"archive_document\",\n\t\tdescription: \"Archive a Chopin document by ID or canonical URL.\",\n\t\tinputSchema: {\n\t\t\ttype: \"object\",\n\t\t\tproperties: {\n\t\t\t\tid: {\n\t\t\t\t\ttype: \"string\",\n\t\t\t\t\tminLength: 1,\n\t\t\t\t\tmaxLength: MAX_DOCUMENT_LOCATOR_LENGTH,\n\t\t\t\t\tpattern: \"\\\\S\",\n\t\t\t\t},\n\t\t\t},\n\t\t\trequired: [\"id\"],\n\t\t\tadditionalProperties: false,\n\t\t},\n\t\toutputSchema: {\n\t\t\toneOf: [\n\t\t\t\tARCHIVED_DOCUMENT,\n\t\t\t\toutcome([\"repository-forbidden\", \"document-unavailable\"]),\n\t\t\t],\n\t\t},\n\t},\n\t{\n\t\tname: \"restore_document\",\n\t\tdescription: \"Restore an archived Chopin document by ID or canonical URL.\",\n\t\tinputSchema: {\n\t\t\ttype: \"object\",\n\t\t\tproperties: {\n\t\t\t\tid: {\n\t\t\t\t\ttype: \"string\",\n\t\t\t\t\tminLength: 1,\n\t\t\t\t\tmaxLength: MAX_DOCUMENT_LOCATOR_LENGTH,\n\t\t\t\t\tpattern: \"\\\\S\",\n\t\t\t\t},\n\t\t\t},\n\t\t\trequired: [\"id\"],\n\t\t\tadditionalProperties: false,\n\t\t},\n\t\toutputSchema: {\n\t\t\toneOf: [\n\t\t\t\tACTIVE_DOCUMENT,\n\t\t\t\toutcome([\"repository-forbidden\", \"document-unavailable\"]),\n\t\t\t],\n\t\t},\n\t},\n\t{\n\t\tname: \"read_implementation\",\n\t\tdescription:\n\t\t\t\"Read the approved implementation graph, plan and repository context by document ID or canonical URL.\",\n\t\tinputSchema: {\n\t\t\ttype: \"object\",\n\t\t\tproperties: {\n\t\t\t\tid: { type: \"string\", minLength: 1, maxLength: MAX_DOCUMENT_LOCATOR_LENGTH },\n\t\t\t},\n\t\t\trequired: [\"id\"],\n\t\t\tadditionalProperties: false,\n\t\t},\n\t\toutputSchema: { type: \"object\", properties: {}, additionalProperties: true },\n\t},\n\t{\n\t\tname: \"start_implementation\",\n\t\tdescription: \"Atomically claim the current approved implementation graph.\",\n\t\tinputSchema: IMPLEMENTATION,\n\t\toutputSchema: { type: \"object\", properties: {}, additionalProperties: true },\n\t},\n\t...LIFECYCLE_TOOLS,\n];\n\ntype Call = {\n\tjsonrpc?: unknown;\n\tid?: unknown;\n\tmethod?: unknown;\n\tparams?: unknown;\n};\n\ntype Reply = {\n\tjsonrpc: \"2.0\";\n\tid: unknown;\n\tresult?: unknown;\n\terror?: { code: number; message: string };\n};\n\nfunction reply(id: unknown, result: unknown): Reply {\n\treturn { jsonrpc: \"2.0\", id: id ?? null, result };\n}\n\nfunction error(id: unknown, code: number, message: string): Reply {\n\treturn { jsonrpc: \"2.0\", id: id ?? null, error: { code, message } };\n}\n\nfunction record(value: unknown): Record | undefined {\n\treturn value && typeof value === \"object\" && !Array.isArray(value)\n\t\t? value as Record\n\t\t: undefined;\n}\n\nfunction text(\n\tvalue: unknown,\n\tisError = false,\n): {\n\tcontent: Array<{ type: \"text\"; text: string }>;\n\tstructuredContent: unknown;\n\tisError?: true;\n} {\n\treturn {\n\t\tcontent: [{ type: \"text\", text: JSON.stringify(value) }],\n\t\tstructuredContent: value,\n\t\t...(isError ? { isError: true as const } : {}),\n\t};\n}\n\nfunction toolCall(\n\tparams: unknown,\n): { name: string; arguments: Record } | undefined {\n\tlet value = record(params);\n\tif (!value || typeof value.name !== \"string\") return undefined;\n\tlet arguments_ = value.arguments === undefined ? {} : record(value.arguments);\n\treturn arguments_ ? { name: value.name, arguments: arguments_ } : undefined;\n}\n\ntype StartArguments = Omit;\n\nfunction startArguments(value: Record): StartArguments | undefined {\n\tlet expected = [\n\t\t\"id\",\n\t\t\"planRevision\",\n\t\t\"graphVersion\",\n\t\t\"graphRevision\",\n\t\t\"repository\",\n\t\t\"branch\",\n\t\t\"commit\",\n\t];\n\tif (\n\t\tObject.keys(value).length !== expected.length\n\t\t|| expected.some(key => !Object.hasOwn(value, key))\n\t) return undefined;\n\tif (\n\t\t!isId(value.id)\n\t\t|| !isRepository(value.repository)\n\t\t|| typeof value.branch !== \"string\"\n\t\t|| !value.branch.trim()\n\t\t|| typeof value.commit !== \"string\"\n\t\t|| !value.commit.trim()\n\t\t|| !Number.isSafeInteger(value.planRevision)\n\t\t|| (value.planRevision as number) < 0\n\t\t|| !Number.isSafeInteger(value.graphVersion)\n\t\t|| (value.graphVersion as number) < 1\n\t\t|| !Number.isSafeInteger(value.graphRevision)\n\t\t|| (value.graphRevision as number) < 1\n\t) return undefined;\n\treturn value as StartArguments;\n}\n\nfunction clientInfo(value: unknown): { name: string; version: string } {\n\tlet info = record(record(value)?.clientInfo);\n\treturn {\n\t\tname: typeof info?.name === \"string\" && info.name.trim() ? info.name : \"unknown\",\n\t\tversion: typeof info?.version === \"string\" && info.version.trim() ? info.version : \"unknown\",\n\t};\n}\n\nfunction isId(value: unknown): value is string {\n\treturn typeof value === \"string\"\n\t\t&& Array.from(value).length <= MAX_DOCUMENT_ID_LENGTH\n\t\t&& value.trim().length > 0;\n}\n\nfunction isLocator(value: unknown): value is string {\n\treturn typeof value === \"string\"\n\t\t&& Array.from(value).length <= MAX_DOCUMENT_LOCATOR_LENGTH\n\t\t&& value.trim().length > 0;\n}\n\nfunction listArguments(\n\tvalue: Record,\n): { repository: string; includeArchived: boolean } | undefined {\n\tlet keys = Object.keys(value);\n\tif (\n\t\t(keys.length !== 1 && keys.length !== 2)\n\t\t|| !Object.hasOwn(value, \"repository\")\n\t\t|| keys.some(key => key !== \"repository\" && key !== \"includeArchived\")\n\t\t|| !isRepository(value.repository)\n\t\t|| (Object.hasOwn(value, \"includeArchived\")\n\t\t\t&& typeof value.includeArchived !== \"boolean\")\n\t) return undefined;\n\treturn {\n\t\trepository: value.repository,\n\t\tincludeArchived: value.includeArchived === true,\n\t};\n}\n\nfunction renameArguments(value: Record): RenameDocumentInput | undefined {\n\tif (\n\t\tObject.keys(value).length !== 2\n\t\t|| !Object.hasOwn(value, \"id\")\n\t\t|| !Object.hasOwn(value, \"title\")\n\t\t|| !isId(value.id)\n\t) return undefined;\n\tlet title = normalizedTitle(value.title);\n\treturn title ? { id: value.id, title } : undefined;\n}\n\nfunction isJsonRpcId(value: unknown): value is string | number | null {\n\treturn value === null || typeof value === \"string\" || typeof value === \"number\";\n}\n\nfunction hasObjectParams(call: Call): boolean {\n\treturn call.params === undefined\n\t\t|| (call.method !== \"initialize\" && call.method !== \"tools/list\")\n\t\t|| record(call.params) !== undefined;\n}\n\nfunction acceptsEvents(request: Request): boolean {\n\tlet selected: { specificity: number; quality: number } | undefined;\n\tfor (let item of (request.headers.get(\"accept\") ?? \"*/*\").split(\",\")) {\n\t\tlet [media, ...parameters] = item.split(\";\").map(value => value.trim());\n\t\tlet specificity = media?.toLowerCase() === \"text/event-stream\"\n\t\t\t? 2\n\t\t\t: media?.toLowerCase() === \"text/*\"\n\t\t\t? 1\n\t\t\t: media === \"*/*\"\n\t\t\t? 0\n\t\t\t: -1;\n\t\tif (specificity < 0) continue;\n\t\tlet quality = 1;\n\t\tlet parameter = parameters.find(value => value.split(\"=\", 1)[0]?.trim().toLowerCase() === \"q\");\n\t\tif (parameter) {\n\t\t\tlet value = parameter.slice(parameter.indexOf(\"=\") + 1).trim();\n\t\t\tquality = /^(?:0(?:\\.\\d{0,3})?|1(?:\\.0{0,3})?)$/.test(value) ? Number(value) : 0;\n\t\t}\n\t\tif (\n\t\t\t!selected\n\t\t\t|| specificity > selected.specificity\n\t\t\t|| (specificity === selected.specificity && quality > selected.quality)\n\t\t) selected = { specificity, quality };\n\t}\n\treturn (selected?.quality ?? 0) > 0;\n}\n\nfunction serviceInstructions(tools: Tool[]): string | undefined {\n\tlet documentMutations = tools.filter(tool =>\n\t\ttool.name === \"create_document\"\n\t\t|| tool.name === \"rename_document\"\n\t\t|| tool.name === \"archive_document\"\n\t\t|| tool.name === \"restore_document\"\n\t);\n\tlet implementation = tools\n\t\t.filter(tool =>\n\t\t\ttool.name === \"read_implementation\"\n\t\t\t|| tool.name === \"start_implementation\"\n\t\t\t|| isLifecycleTool(tool.name)\n\t\t);\n\treturn [\n\t\t\"Chopin's MCP contract and current tool descriptions are authoritative.\",\n\t\t...documentMutations.map(tool => `${tool.name}: ${tool.description}`),\n\t\t...(implementation.length > 0\n\t\t\t? [\n\t\t\t\t\"Read the canonical implementation before every implementation or lifecycle action; copied plans and lifecycle instructions are not substitutes.\",\n\t\t\t\t...implementation.map(tool => `${tool.name}: ${tool.description}`),\n\t\t\t]\n\t\t\t: []),\n\t].join(\"\\n\");\n}\n\nasync function requestBody(request: Request): Promise<{ body?: unknown; tooLarge: boolean }> {\n\tlet declared = request.headers.get(\"content-length\");\n\tif (declared && /^\\d+$/.test(declared) && Number(declared) > MAX_REQUEST_BYTES) {\n\t\treturn { tooLarge: true };\n\t}\n\n\tlet reader = request.body?.getReader();\n\tif (!reader) throw new Error(\"request has no body\");\n\tlet chunks: Uint8Array[] = [];\n\tlet length = 0;\n\ttry {\n\t\twhile (true) {\n\t\t\tlet { done, value } = await reader.read();\n\t\t\tif (done) break;\n\t\t\tif (!value) continue;\n\t\t\tlength += value.byteLength;\n\t\t\tif (length > MAX_REQUEST_BYTES) {\n\t\t\t\tawait reader.cancel().catch(() => {});\n\t\t\t\treturn { tooLarge: true };\n\t\t\t}\n\t\t\tchunks.push(value);\n\t\t}\n\t} finally {\n\t\treader.releaseLock();\n\t}\n\n\tlet bytes = new Uint8Array(length);\n\tlet offset = 0;\n\tfor (let chunk of chunks) {\n\t\tbytes.set(chunk, offset);\n\t\toffset += chunk.byteLength;\n\t}\n\treturn { body: JSON.parse(new TextDecoder().decode(bytes)), tooLarge: false };\n}\n\n/** A stateless JSON-response Streamable HTTP MCP handler. */\nexport function handler(\n\toptions: McpOptions,\n): (request: Request) => Promise {\n\tlet creation = options.create;\n\tlet renaming = options.rename;\n\tlet archiving = options.archive;\n\tlet restoring = options.restore;\n\tlet sessions = new Map();\n\tlet tools = TOOLS.filter(tool =>\n\t\t(tool.name !== \"create_document\" || creation)\n\t\t&& (tool.name !== \"rename_document\" || renaming)\n\t\t&& (tool.name !== \"archive_document\" || archiving)\n\t\t&& (tool.name !== \"restore_document\" || restoring)\n\t\t&& (![\"read_implementation\", \"start_implementation\"].includes(tool.name)\n\t\t\t|| options.implementations)\n\t\t&& (!isLifecycleTool(tool.name) || options.implementations?.reportLifecycle)\n\t);\n\tlet instructions = serviceInstructions(tools);\n\n\tasync function dispatch(\n\t\tvalue: unknown,\n\t\tcaller: Caller,\n\t\tclient: { name: string; version: string; session: string },\n\t\tcreated: { session?: string },\n\t): Promise {\n\t\tlet call = record(value) as Call | undefined;\n\t\tif (!call || call.jsonrpc !== \"2.0\" || typeof call.method !== \"string\") {\n\t\t\treturn error(call?.id, -32600, \"invalid request\");\n\t\t}\n\t\tif (Object.hasOwn(call, \"id\") && !isJsonRpcId(call.id)) {\n\t\t\treturn error(null, -32600, \"invalid request\");\n\t\t}\n\t\tif (!hasObjectParams(call)) return error(call.id, -32600, \"invalid request\");\n\t\tlet notification = !Object.hasOwn(call, \"id\");\n\t\tlet respond = (result: unknown) => notification ? undefined : reply(call.id, result);\n\n\t\tswitch (call.method) {\n\t\t\tcase \"initialize\": {\n\t\t\t\tlet session = crypto.randomUUID();\n\t\t\t\tsessions.set(session, clientInfo(call.params));\n\t\t\t\tcreated.session = session;\n\t\t\t\treturn respond({\n\t\t\t\t\tprotocolVersion: \"2025-03-26\",\n\t\t\t\t\tcapabilities: { tools: {} },\n\t\t\t\t\tserverInfo: { name: \"chopin\", version: \"0.0.0\" },\n\t\t\t\t\t...(instructions ? { instructions } : {}),\n\t\t\t\t});\n\t\t\t}\n\n\t\t\tcase \"notifications/initialized\":\n\t\t\t\treturn undefined;\n\n\t\t\tcase \"tools/list\":\n\t\t\t\treturn respond({ tools });\n\n\t\t\tcase \"tools/call\": {\n\t\t\t\tlet tool = toolCall(call.params);\n\t\t\t\tif (!tool) {\n\t\t\t\t\treturn notification\n\t\t\t\t\t\t? undefined\n\t\t\t\t\t\t: error(call.id, -32602, \"invalid tool arguments\");\n\t\t\t\t}\n\t\t\t\tif (tool.name === \"list_documents\") {\n\t\t\t\t\tlet input = listArguments(tool.arguments);\n\t\t\t\t\tif (!input) {\n\t\t\t\t\t\treturn notification\n\t\t\t\t\t\t\t? undefined\n\t\t\t\t\t\t\t: error(call.id, -32602, \"list_documents requires a repository\");\n\t\t\t\t\t}\n\t\t\t\t\tlet documents = await options.documents.list(\n\t\t\t\t\t\tcaller,\n\t\t\t\t\t\tinput.repository,\n\t\t\t\t\t\tinput.includeArchived,\n\t\t\t\t\t);\n\t\t\t\t\treturn documents === \"forbidden\"\n\t\t\t\t\t\t? respond(text({ code: \"repository-forbidden\" }, true))\n\t\t\t\t\t\t: respond(text({ documents }));\n\t\t\t\t}\n\t\t\t\tif (tool.name === \"read_document\") {\n\t\t\t\t\tif (Object.keys(tool.arguments).length !== 1 || !isLocator(tool.arguments.id)) {\n\t\t\t\t\t\treturn notification\n\t\t\t\t\t\t\t? undefined\n\t\t\t\t\t\t\t: error(call.id, -32602, \"read_document requires an id or URL\");\n\t\t\t\t\t}\n\t\t\t\t\tlet document = await options.documents.read(caller, tool.arguments.id);\n\t\t\t\t\treturn document ? respond(text(document)) : respond({ content: [], isError: true });\n\t\t\t\t}\n\t\t\t\tif (tool.name === \"create_document\" && creation) {\n\t\t\t\t\tlet prepared = prepare(tool.arguments);\n\t\t\t\t\tif (!prepared) {\n\t\t\t\t\t\treturn notification\n\t\t\t\t\t\t\t? undefined\n\t\t\t\t\t\t\t: error(call.id, -32602, \"create_document requires a valid draft\");\n\t\t\t\t\t}\n\t\t\t\t\tif (\"issues\" in prepared) return respond(text({ issues: prepared.issues }, true));\n\t\t\t\t\tlet outcome = await creation.create(caller, prepared.input);\n\t\t\t\t\tif (outcome.kind === \"created\" || outcome.kind === \"replayed\") {\n\t\t\t\t\t\treturn respond(text(outcome.document));\n\t\t\t\t\t}\n\t\t\t\t\tif (outcome.kind === \"conflict\") {\n\t\t\t\t\t\treturn respond(text({ code: \"idempotency-conflict\" }, true));\n\t\t\t\t\t}\n\t\t\t\t\tif (outcome.kind === \"unavailable\") {\n\t\t\t\t\t\treturn respond(text({ code: \"document-unavailable\" }, true));\n\t\t\t\t\t}\n\t\t\t\t\treturn respond({ content: [], isError: true });\n\t\t\t\t}\n\t\t\t\tif (tool.name === \"rename_document\" && renaming) {\n\t\t\t\t\tlet input = renameArguments(tool.arguments);\n\t\t\t\t\tif (!input) {\n\t\t\t\t\t\treturn notification\n\t\t\t\t\t\t\t? undefined\n\t\t\t\t\t\t\t: error(call.id, -32602, \"rename_document requires an id and valid title\");\n\t\t\t\t\t}\n\t\t\t\t\tlet outcome = await renaming.rename(caller, input);\n\t\t\t\t\tif (outcome.kind === \"renamed\" || outcome.kind === \"unchanged\") {\n\t\t\t\t\t\treturn respond(text(outcome.document));\n\t\t\t\t\t}\n\t\t\t\t\tlet code = outcome.kind === \"archived\"\n\t\t\t\t\t\t? \"document-archived\"\n\t\t\t\t\t\t: outcome.kind === \"conflict\"\n\t\t\t\t\t\t? \"title-conflict\"\n\t\t\t\t\t\t: outcome.kind === \"forbidden\"\n\t\t\t\t\t\t? \"repository-forbidden\"\n\t\t\t\t\t\t: \"document-unavailable\";\n\t\t\t\t\treturn respond(text({ code }, true));\n\t\t\t\t}\n\t\t\t\tif (tool.name === \"archive_document\" && archiving) {\n\t\t\t\t\tif (Object.keys(tool.arguments).length !== 1 || !isLocator(tool.arguments.id)) {\n\t\t\t\t\t\treturn notification\n\t\t\t\t\t\t\t? undefined\n\t\t\t\t\t\t\t: error(call.id, -32602, \"archive_document requires an id or URL\");\n\t\t\t\t\t}\n\t\t\t\t\tlet outcome = await archiving.archive(caller, tool.arguments.id);\n\t\t\t\t\tif (outcome.kind === \"archived\" || outcome.kind === \"unchanged\") {\n\t\t\t\t\t\treturn respond(text(outcome.document));\n\t\t\t\t\t}\n\t\t\t\t\treturn respond(text({\n\t\t\t\t\t\tcode: outcome.kind === \"forbidden\"\n\t\t\t\t\t\t\t? \"repository-forbidden\"\n\t\t\t\t\t\t\t: \"document-unavailable\",\n\t\t\t\t\t}, true));\n\t\t\t\t}\n\t\t\t\tif (tool.name === \"restore_document\" && restoring) {\n\t\t\t\t\tif (Object.keys(tool.arguments).length !== 1 || !isLocator(tool.arguments.id)) {\n\t\t\t\t\t\treturn notification\n\t\t\t\t\t\t\t? undefined\n\t\t\t\t\t\t\t: error(call.id, -32602, \"restore_document requires an id or URL\");\n\t\t\t\t\t}\n\t\t\t\t\tlet outcome = await restoring.restore(caller, tool.arguments.id);\n\t\t\t\t\tif (outcome.kind === \"restored\" || outcome.kind === \"unchanged\") {\n\t\t\t\t\t\treturn respond(text(outcome.document));\n\t\t\t\t\t}\n\t\t\t\t\treturn respond(text({\n\t\t\t\t\t\tcode: outcome.kind === \"forbidden\"\n\t\t\t\t\t\t\t? \"repository-forbidden\"\n\t\t\t\t\t\t\t: \"document-unavailable\",\n\t\t\t\t\t}, true));\n\t\t\t\t}\n\t\t\t\tif (tool.name === \"read_implementation\") {\n\t\t\t\t\tif (Object.keys(tool.arguments).length !== 1 || !isLocator(tool.arguments.id)) {\n\t\t\t\t\t\treturn notification\n\t\t\t\t\t\t\t? undefined\n\t\t\t\t\t\t\t: error(call.id, -32602, \"read_implementation requires an id or URL\");\n\t\t\t\t\t}\n\t\t\t\t\tif (!options.implementations) {\n\t\t\t\t\t\treturn respond(text({ code: \"implementation-unavailable\" }, true));\n\t\t\t\t\t}\n\t\t\t\t\tlet implementation = await options.implementations.readImplementation(\n\t\t\t\t\t\tcaller,\n\t\t\t\t\t\ttool.arguments.id,\n\t\t\t\t\t);\n\t\t\t\t\tif (implementation === \"forbidden\") {\n\t\t\t\t\t\treturn respond(text({ code: \"repository-forbidden\" }, true));\n\t\t\t\t\t}\n\t\t\t\t\treturn implementation\n\t\t\t\t\t\t? respond(text(implementation))\n\t\t\t\t\t\t: respond(text({ code: \"implementation-unavailable\" }, true));\n\t\t\t\t}\n\t\t\t\tif (tool.name === \"start_implementation\") {\n\t\t\t\t\tlet input = startArguments(tool.arguments);\n\t\t\t\t\tif (!input) {\n\t\t\t\t\t\treturn notification\n\t\t\t\t\t\t\t? undefined\n\t\t\t\t\t\t\t: error(call.id, -32602, \"start_implementation requires current revisions\");\n\t\t\t\t\t}\n\t\t\t\t\tif (!client.session || !sessions.has(client.session)) {\n\t\t\t\t\t\treturn respond(text({ code: \"session-required\" }, true));\n\t\t\t\t\t}\n\t\t\t\t\tif (!options.implementations) {\n\t\t\t\t\t\treturn respond(text({ code: \"implementation-unavailable\" }, true));\n\t\t\t\t\t}\n\t\t\t\t\tlet outcome = await options.implementations.startImplementation(caller, {\n\t\t\t\t\t\t...input,\n\t\t\t\t\t\tclient,\n\t\t\t\t\t});\n\t\t\t\t\tif (outcome.kind === \"started\" || outcome.kind === \"active\") {\n\t\t\t\t\t\treturn respond(text({ state: outcome.kind, run: outcome.run }));\n\t\t\t\t\t}\n\t\t\t\t\tif (outcome.kind === \"forbidden\") {\n\t\t\t\t\t\treturn respond(text({ code: \"repository-forbidden\" }, true));\n\t\t\t\t\t}\n\t\t\t\t\tif (outcome.kind === \"unavailable\") {\n\t\t\t\t\t\treturn respond(text({ code: \"document-unavailable\" }, true));\n\t\t\t\t\t}\n\t\t\t\t\treturn respond(text({ code: outcome.reason }, true));\n\t\t\t\t}\n\t\t\t\tlet lifecycle = lifecycleCall(tool.name, tool.arguments);\n\t\t\t\tif (lifecycle.known) {\n\t\t\t\t\tif (!lifecycle.input) {\n\t\t\t\t\t\treturn notification\n\t\t\t\t\t\t\t? undefined\n\t\t\t\t\t\t\t: error(call.id, -32602, `${tool.name} requires its documented arguments`);\n\t\t\t\t\t}\n\t\t\t\t\tif (!client.session || !sessions.has(client.session)) {\n\t\t\t\t\t\treturn respond(text({ code: \"session-required\" }, true));\n\t\t\t\t\t}\n\t\t\t\t\tlet report = options.implementations?.reportLifecycle;\n\t\t\t\t\tif (!report) return respond(text({ code: \"implementation-unavailable\" }, true));\n\t\t\t\t\tlet outcome = await report(caller, lifecycle.input);\n\t\t\t\t\tif (outcome.kind === \"accepted\" || outcome.kind === \"replayed\") {\n\t\t\t\t\t\treturn respond(text(outcome.lifecycle));\n\t\t\t\t\t}\n\t\t\t\t\tif (outcome.kind === \"forbidden\") {\n\t\t\t\t\t\treturn respond(text({ code: \"repository-forbidden\" }, true));\n\t\t\t\t\t}\n\t\t\t\t\tif (outcome.kind === \"unavailable\") {\n\t\t\t\t\t\treturn respond(text({ code: \"document-unavailable\" }, true));\n\t\t\t\t\t}\n\t\t\t\t\treturn outcome.kind === \"refused\"\n\t\t\t\t\t\t? respond(text({ code: outcome.reason }, true))\n\t\t\t\t\t\t: respond(text({ code: \"implementation-unavailable\" }, true));\n\t\t\t\t}\n\t\t\t\treturn notification ? undefined : error(call.id, -32601, \"tool not found\");\n\t\t\t}\n\n\t\t\tdefault:\n\t\t\t\treturn notification ? undefined : error(call.id, -32601, \"method not found\");\n\t\t}\n\t}\n\n\treturn async request => {\n\t\tlet caller = await options.caller(request);\n\t\tif (caller === undefined) return new Response(\"unauthorized\", { status: 401 });\n\n\t\tif (request.method === \"GET\") {\n\t\t\tif (!acceptsEvents(request)) return new Response(\"not acceptable\", { status: 406 });\n\t\t\treturn new Response(null, {\n\t\t\t\theaders: { \"cache-control\": \"no-cache\", \"content-type\": \"text/event-stream\" },\n\t\t\t});\n\t\t}\n\t\tif (request.method !== \"POST\") {\n\t\t\treturn new Response(\"method not allowed\", { status: 405, headers: { allow: \"GET, POST\" } });\n\t\t}\n\n\t\tlet session = request.headers.get(\"mcp-session-id\") ?? \"\";\n\t\tlet client = { ...(sessions.get(session) ?? { name: \"unknown\", version: \"unknown\" }), session };\n\t\tlet created: { session?: string } = {};\n\t\tlet body: unknown;\n\t\ttry {\n\t\t\tlet read = await requestBody(request);\n\t\t\tif (read.tooLarge) return new Response(\"request too large\", { status: 413 });\n\t\t\tbody = read.body;\n\t\t} catch {\n\t\t\treturn Response.json(error(null, -32700, \"parse error\"));\n\t\t}\n\t\tlet result = await dispatch(body, caller, client, created);\n\t\treturn result\n\t\t\t? Response.json(result, {\n\t\t\t\theaders: created.session ? { \"mcp-session-id\": created.session } : undefined,\n\t\t\t})\n\t\t\t: new Response(null, { status: 202 });\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",1794439270014,"sidebar","expanded"]