[{"_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","8f4eba80fdd9a4cfb6bbbfba696b39228ce8a763","path","apps/server/src/mcp.ts","oid","3abc46207df4eddb7ea0cbdcaacc31814876bef7","size",9823,"commit","mounts",[],"source","plain",{"_13":14,"_15":16},"kind","text","/**\n * Backend-neutral MCP read protocol.\n *\n * Hosts authenticate callers and resolve repository-scoped documents. This\n * module only validates and presents their results through MCP.\n */\n\nexport type DocumentSummary = {\n\tid: string;\n\ttitle: string;\n};\n\nexport type Document = DocumentSummary & {\n\tsource: string;\n\trevision: number;\n};\n\nexport type DocumentReader = {\n\tlist(caller: Caller, repository: string): Promise;\n\tread(caller: Caller, id: string): Promise;\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};\n\ntype Tool = {\n\tname: string;\n\tdescription: string;\n\tinputSchema: Record;\n\toutputSchema: Record;\n};\n\nconst OWNER_PATTERN = \"[A-Za-z0-9](?:[A-Za-z0-9]|-(?=[A-Za-z0-9])){0,38}\";\nconst REPOSITORY_PATTERN = \"(?!\\\\.\\\\.?$)[A-Za-z0-9._-]{1,100}\";\nconst REPOSITORY_PATH_PATTERN = `^${OWNER_PATTERN}/${REPOSITORY_PATTERN}$`;\nconst OWNER = new RegExp(`^${OWNER_PATTERN}$`);\nconst REPOSITORY = new RegExp(`^${REPOSITORY_PATTERN}$`);\nconst MAX_DOCUMENT_ID_LENGTH = 128;\n/** Read-only JSON-RPC calls need arguments, not document-sized request bodies. */\nconst MAX_REQUEST_BYTES = 64 * 1_024;\n\nconst DOCUMENT = {\n\ttype: \"object\",\n\tproperties: {\n\t\tid: { type: \"string\" },\n\t\ttitle: { type: \"string\" },\n\t},\n\trequired: [\"id\", \"title\"],\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},\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 channel's canonical source and 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},\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\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];\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): { content: Array<{ type: \"text\"; text: string }>; structuredContent: unknown } {\n\treturn {\n\t\tcontent: [{ type: \"text\", text: JSON.stringify(value) }],\n\t\tstructuredContent: value,\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\nfunction isRepository(value: unknown): value is string {\n\tif (typeof value !== \"string\") return false;\n\tlet parts = value.split(\"/\");\n\treturn parts.length === 2 && OWNER.test(parts[0]!) && REPOSITORY.test(parts[1]!);\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 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\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 for read-only tools. */\nexport function handler(\n\toptions: McpOptions,\n): (request: Request) => Promise {\n\tasync function dispatch(value: unknown, caller: Caller): 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\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});\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: 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\tif (\n\t\t\t\t\t\tObject.keys(tool.arguments).length !== 1 || !isRepository(tool.arguments.repository)\n\t\t\t\t\t) {\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\treturn respond(\n\t\t\t\t\t\ttext({ documents: await options.documents.list(caller, tool.arguments.repository) }),\n\t\t\t\t\t);\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 || !isId(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\");\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\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 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);\n\t\treturn result ? Response.json(result) : 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",1794476991529,"sidebar","expanded"]