[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10,"_11":12},"actionData","errors","root",{"_229":-5,"_232":233,"_234":235},"routes/shell",{"_42":43,"_228":-5,"_229":-5,"_230":231},"routes/repo",{"_33":-7,"_34":35,"_36":37,"_38":39,"_40":41,"_42":43,"_44":31,"_45":31,"_46":31,"_47":31,"_48":31,"_49":31,"_50":51,"_52":51,"_53":31,"_54":-7,"_55":-7,"_56":57,"_58":59,"_60":61,"_62":-5,"_63":64,"_65":66,"_67":68,"_69":70},"routes/repo.blob",{"_13":14,"_15":16,"_17":18,"_19":20,"_21":14,"_22":23,"_24":-5,"_25":26,"_27":28,"_28":29,"_30":31,"_32":14},"ref","0e97df97a06108f8143d6b4090141e8e2e94ac0d","path","apps/server/src/research/service.ts","oid","625a1813f7d479b68324ec324739d4a1fb603078","size",44736,"commit","mounts",[],"source","plain",{"_13":14,"_15":16},"kind","text","import { createHash } from \"node:crypto\";\n\nimport { jobDetail as serializedJobDetail } from \"../jobs/browser\";\nimport {\n\tparseResearchAnswerArtifact,\n\tparseResearchAnswerInput,\n\tparseResearchEvidenceArtifact,\n} from \"../jobs/research-workspace\";\nimport { RESEARCH_REPOSITORY_WORKSPACE_LIMIT } from \"../storage/model\";\nimport * as Plan from \"../plan/service\";\n\nimport type { Job, Research } from \"@chopin/protocol\";\nimport type {\n\tResearchAnswerInput,\n\tResearchEvidence,\n\tResearchReport,\n} from \"../jobs/research-workspace\";\nimport type { JobDetail, JobService, JobView } from \"../jobs/service\";\nimport type { DocumentTarget } from \"../plan/service\";\nimport type {\n\tJsonValue,\n\tLease,\n\tResearchMessage,\n\tResearchTurn,\n\tResearchTurnKind,\n\tResearchWorkspace,\n\tResearchWorkspaceDetail,\n\tResearchWorkspaceOrigin,\n\tResearchWorkspaceRepositoryChannel,\n} from \"../storage/model\";\nimport type { StorageAdapter } from \"../storage/port\";\n\nexport type ResearchWorkspaceErrorCode =\n\t| \"active-turn\"\n\t| \"invalid-request\"\n\t| \"invalid-state\"\n\t| \"not-found\"\n\t| \"not-ready\";\n\nexport class ResearchWorkspaceError extends Error {\n\treadonly code: ResearchWorkspaceErrorCode;\n\n\tconstructor(code: ResearchWorkspaceErrorCode, message: string, options?: ErrorOptions) {\n\t\tsuper(message, options);\n\t\tthis.name = \"ResearchWorkspaceError\";\n\t\tthis.code = code;\n\t}\n}\n\nexport type ResearchWorkspaceServiceOptions = {\n\tstorage: StorageAdapter;\n\tjobs: JobService;\n\tlease: () => Lease;\n\tcurrent: (channelId: string) => Promise;\n\tpublish: (\n\t\tchannelId: string,\n\t\tworkspaceId: string,\n\t\trevision: number,\n\t) => void | Promise;\n\tclock?: () => Date;\n\tid?: () => string;\n};\n\nexport type CreateResearchDraft = {\n\tchannelId: string;\n\tquestion: string;\n\torigin: ResearchWorkspaceOrigin;\n\tcreatedBy: string;\n\trequestId?: string;\n\toriginMessageId?: string;\n};\n\nexport type CreateResearchDraftResult = {\n\tworkspace: Research.WorkspaceSummary;\n\trepeated: boolean;\n};\n\nexport type StartResearchRequest = {\n\tchannelId: string;\n\tquestion: string;\n\trequestId: string;\n\trequestedBy: string;\n\trequestedByHandle?: string;\n\tbeforeStart?: () => void | Promise;\n};\n\nexport type StartResearchRequestResult = {\n\trequest: Research.RequestView;\n\trepeated: boolean;\n};\n\nexport type ConfirmResearchDraft = {\n\tchannelId: string;\n\tworkspaceId: string;\n\tquery: string;\n\trequestId: string;\n\tconfirmedBy: string;\n\tconfirmedByHandle?: string;\n\tbeforeStart?: () => void | Promise;\n};\n\nexport type AppendResearchWorkspaceTurn = {\n\tchannelId: string;\n\tworkspaceId: string;\n\tkind: Exclude;\n\tquestion: string;\n\trequestId: string;\n\trequestedBy: string;\n\trequestedByHandle?: string;\n\tbeforeStart?: () => void | Promise;\n};\n\nexport type CancelResearchWorkspaceTurn = {\n\tchannelId: string;\n\tworkspaceId: string;\n\tturnId: string;\n};\n\nexport type CancelResearchRequest = {\n\tchannelId: string;\n\tworkspaceId: string;\n};\n\nexport type ResearchWorkspaceTurnView = Research.Turn & {\n\treadonly evidence?: Job.Detail;\n\treadonly answer?: Job.Detail;\n};\n\nexport type ResearchWorkspaceView = Omit & {\n\treadonly turns: readonly ResearchWorkspaceTurnView[];\n};\n\nexport type ResearchWorkspaceParent = ResearchWorkspaceRepositoryChannel;\n\nexport type RepositoryResearchWorkspaceGroup = {\n\tchannel: ResearchWorkspaceParent;\n\tworkspaces: Research.WorkspaceSummary[];\n};\n\nexport type RepositoryResearchWorkspaceList = {\n\tchannels: RepositoryResearchWorkspaceGroup[];\n\ttruncated: boolean;\n};\n\nconst MAX_ID = 96;\nconst MAX_OPAQUE_ID = 255;\nconst MAX_ORIGIN_MESSAGE_ID = 128;\nconst MAX_QUESTION = 4_096;\nconst MAX_TITLE = 120;\nconst MAX_TURNS = 100;\nconst MAX_HISTORY = 100;\nconst MAX_HISTORY_TEXT = 4_096;\nconst MAX_HISTORY_BYTES = 256 * 1024;\nconst MAX_EVIDENCE_BATCHES = 32;\nconst MAX_EVIDENCE_FINDINGS = 64;\nconst MAX_EVIDENCE_SOURCES = 64;\nconst MAX_TARGET_SCAN = 1_000;\nconst REQUEST_ID = /^[0-9a-f]{8}-[0-9a-f]{4}-4[0-9a-f]{3}-[89ab][0-9a-f]{3}-[0-9a-f]{12}$/i;\nconst SAFE_ID = /^[A-Za-z0-9][A-Za-z0-9._:-]*$/;\nconst HANDLE = /^[A-Za-z0-9](?:[A-Za-z0-9-]{0,38})$/;\nconst ACTIVE_JOB_STATES = new Set([\"pending\", \"paused\", \"running\"]);\n\nfunction digest(value: string): string {\n\treturn createHash(\"sha256\").update(value).digest(\"hex\");\n}\n\nfunction fingerprint(kind: string, value: JsonValue): string {\n\treturn digest(`${kind}\\0${JSON.stringify(value)}`);\n}\n\nfunction safeId(value: unknown, field: string, maximum = MAX_ID): string {\n\tif (\n\t\ttypeof value !== \"string\" || value.length < 1 || value.length > maximum\n\t\t|| !SAFE_ID.test(value)\n\t) {\n\t\tthrow new ResearchWorkspaceError(\"invalid-request\", `${field} is invalid.`);\n\t}\n\treturn value;\n}\n\nfunction requestId(value: unknown): string {\n\tif (typeof value !== \"string\" || !REQUEST_ID.test(value)) {\n\t\tthrow new ResearchWorkspaceError(\"invalid-request\", \"Request id is invalid.\");\n\t}\n\treturn value;\n}\n\nfunction handle(value: string | undefined): string | undefined {\n\tif (value === undefined) return undefined;\n\tif (!HANDLE.test(value)) {\n\t\tthrow new ResearchWorkspaceError(\"invalid-request\", \"Member handle is invalid.\");\n\t}\n\treturn value;\n}\n\nfunction hasControlCharacter(value: string): boolean {\n\tfor (let index = 0; index < value.length; index++) {\n\t\tlet code = value.charCodeAt(index);\n\t\tif (code <= 8 || code === 11 || code === 12 || code >= 14 && code <= 31 || code === 127) {\n\t\t\treturn true;\n\t\t}\n\t}\n\treturn false;\n}\n\n/** GitHub node IDs are opaque and may use padded Base64 characters such as `=`. */\nfunction opaqueId(value: unknown, field: string): string {\n\tif (\n\t\ttypeof value !== \"string\" || value.length < 1 || value.length > MAX_OPAQUE_ID\n\t\t|| hasControlCharacter(value)\n\t) throw new ResearchWorkspaceError(\"invalid-request\", `${field} is invalid.`);\n\treturn value;\n}\n\nexport function normalizeResearchPrompt(value: unknown): string {\n\tif (typeof value !== \"string\") {\n\t\tthrow new ResearchWorkspaceError(\"invalid-request\", \"Research question is invalid.\");\n\t}\n\tlet normalized = value.trim().replace(/\\s+/g, \" \");\n\tif (!normalized || normalized.length > MAX_QUESTION || hasControlCharacter(normalized)) {\n\t\tthrow new ResearchWorkspaceError(\n\t\t\t\"invalid-request\",\n\t\t\t`Research question must contain between 1 and ${MAX_QUESTION} characters.`,\n\t\t);\n\t}\n\treturn normalized;\n}\n\nfunction researchBrief(value: unknown): string {\n\tif (\n\t\ttypeof value !== \"string\" || !value.trim() || value.length > MAX_QUESTION\n\t\t|| hasControlCharacter(value)\n\t) {\n\t\tthrow new ResearchWorkspaceError(\n\t\t\t\"invalid-request\",\n\t\t\t`Research question must contain between 1 and ${MAX_QUESTION} characters.`,\n\t\t);\n\t}\n\treturn value;\n}\n\nexport function researchWorkspaceTitle(question: string): string {\n\tlet points = [...normalizeResearchPrompt(question)];\n\treturn points.length <= MAX_TITLE\n\t\t? points.join(\"\")\n\t\t: `${points.slice(0, MAX_TITLE - 3).join(\"\").trimEnd()}...`;\n}\n\nfunction suffixedResearchTitle(title: string, suffix: string): string {\n\tlet points = [...title];\n\tlet suffixPoints = [...suffix];\n\treturn `${points.slice(0, MAX_TITLE - suffixPoints.length).join(\"\").trimEnd()}${suffix}`;\n}\n\nfunction researchReportText(value: string): string {\n\treturn value.trim().replace(/\\s+/g, \" \").replace(/[\\\\`*_[\\]{}<>]/g, \"\\\\$&\");\n}\n\nfunction researchReportSource(\n\treport: ResearchReport,\n\tsources: ResearchEvidence[\"sources\"],\n): string {\n\tlet blocks = [`# ${researchReportText(report.title)}`, researchReportText(report.summary)];\n\tif (report.findings.length > 0) {\n\t\tblocks.push(\"## Findings\");\n\t\tfor (let finding of report.findings) {\n\t\t\tlet sourceText = finding.sourceUrls.length > 0\n\t\t\t\t? ` Sources: ${finding.sourceUrls.join(\", \")}`\n\t\t\t\t: \"\";\n\t\t\tblocks.push(`- ${researchReportText(finding.text)}${sourceText}`);\n\t\t}\n\t}\n\tif (report.caveats.length > 0) {\n\t\tblocks.push(\"## Caveats\");\n\t\tfor (let caveat of report.caveats) blocks.push(`- ${researchReportText(caveat)}`);\n\t}\n\tif (sources.length > 0) {\n\t\tblocks.push(\"## Sources\");\n\t\tfor (let source of sources) {\n\t\t\tblocks.push(`- ${researchReportText(source.title)}: ${source.url}`);\n\t\t}\n\t}\n\treturn `${blocks.join(\"\\n\\n\")}\\n`;\n}\n\nfunction summary(value: ResearchWorkspace): Research.WorkspaceSummary {\n\treturn {\n\t\tid: value.id,\n\t\tchannelId: value.channelId,\n\t\ttitle: value.title,\n\t\tproposedQuestion: value.proposedQuestion,\n\t\t...(value.confirmedQuery !== undefined ? { confirmedQuery: value.confirmedQuery } : {}),\n\t\torigin: value.origin,\n\t\t...(value.originMessageId !== undefined ? { originMessageId: value.originMessageId } : {}),\n\t\tcreatedBy: value.createdBy,\n\t\t...(value.confirmedBy !== undefined ? { confirmedBy: value.confirmedBy } : {}),\n\t\trevision: value.revision,\n\t\tcreatedAt: value.createdAt.toISOString(),\n\t\tupdatedAt: value.updatedAt.toISOString(),\n\t};\n}\n\nfunction message(value: ResearchMessage): Research.Message {\n\treturn {\n\t\tid: value.id,\n\t\tworkspaceId: value.workspaceId,\n\t\tsequence: value.sequence,\n\t\t...(value.turnId !== undefined ? { turnId: value.turnId } : {}),\n\t\tauthorKind: value.authorKind,\n\t\t...(value.userId !== undefined ? { userId: value.userId } : {}),\n\t\t...(value.userHandle !== undefined ? { userHandle: value.userHandle } : {}),\n\t\ttext: value.text,\n\t\t...(value.sourceJobId !== undefined ? { sourceJobId: value.sourceJobId } : {}),\n\t\tcreatedAt: value.createdAt.toISOString(),\n\t};\n}\n\nfunction turn(value: ResearchTurn): Research.Turn {\n\treturn {\n\t\tid: value.id,\n\t\tworkspaceId: value.workspaceId,\n\t\tordinal: value.ordinal,\n\t\tkind: value.kind,\n\t\tquestion: value.question,\n\t\trequestedBy: value.requestedBy,\n\t\t...(value.evidenceJobId !== undefined ? { evidenceJobId: value.evidenceJobId } : {}),\n\t\t...(value.answerJobId !== undefined ? { answerJobId: value.answerJobId } : {}),\n\t\tcreatedAt: value.createdAt.toISOString(),\n\t\tupdatedAt: value.updatedAt.toISOString(),\n\t};\n}\n\nfunction boundedHistoryText(value: string, maximumBytes: number): string {\n\tlet output = \"\";\n\tlet bytes = 0;\n\tlet characters = 0;\n\tfor (let point of value.trim()) {\n\t\tlet size = Buffer.byteLength(point);\n\t\tif (characters >= MAX_HISTORY_TEXT || bytes + size > maximumBytes) break;\n\t\toutput += point;\n\t\tbytes += size;\n\t\tcharacters++;\n\t}\n\treturn output.trim();\n}\n\nexport function boundedResearchEvidence(evidence: ResearchEvidence[]): ResearchEvidence[] {\n\tif (evidence.length <= 1) return evidence.map(batch => structuredClone(batch));\n\tlet selected = [evidence[0]!, ...evidence.slice(1).toReversed()];\n\tlet bounded: ResearchEvidence[] = [];\n\tlet findings = 0;\n\tlet sources = 0;\n\tfor (let batch of selected) {\n\t\tif (bounded.length >= MAX_EVIDENCE_BATCHES) break;\n\t\tlet remainingFindings = MAX_EVIDENCE_FINDINGS - findings;\n\t\tlet remainingSources = MAX_EVIDENCE_SOURCES - sources;\n\t\tif (remainingFindings <= 0 && remainingSources <= 0) break;\n\t\tlet nextSources = batch.sources.slice(0, Math.max(0, remainingSources))\n\t\t\t.map(source => ({ ...source }));\n\t\tlet nextFindings = nextSources.length > 0\n\t\t\t? batch.findings.slice(0, Math.max(0, remainingFindings))\n\t\t\t: [];\n\t\tif (nextFindings.length === 0 && nextSources.length === 0) continue;\n\t\tbounded.push({ findings: nextFindings, sources: nextSources });\n\t\tfindings += nextFindings.length;\n\t\tsources += nextSources.length;\n\t}\n\treturn bounded;\n}\n\n/** Coordinates durable workspace state with independently durable background jobs. */\nexport class ResearchWorkspaceService {\n\t#storage: StorageAdapter;\n\t#jobs: JobService;\n\t#lease: () => Lease;\n\t#current: (channelId: string) => Promise;\n\t#publish: ResearchWorkspaceServiceOptions[\"publish\"];\n\t#clock: () => Date;\n\t#id: () => string;\n\t#tails = new Map>();\n\n\tconstructor(options: ResearchWorkspaceServiceOptions) {\n\t\tthis.#storage = options.storage;\n\t\tthis.#jobs = options.jobs;\n\t\tthis.#lease = options.lease;\n\t\tthis.#current = options.current;\n\t\tthis.#publish = options.publish;\n\t\tthis.#clock = options.clock ?? (() => new Date());\n\t\tthis.#id = options.id ?? (() => crypto.randomUUID());\n\t}\n\n\tasync start(input: StartResearchRequest): Promise {\n\t\tlet channelId = safeId(input.channelId, \"Channel id\");\n\t\tlet question = researchBrief(input.question);\n\t\tlet durableRequestId = requestId(input.requestId);\n\t\tlet requestedBy = opaqueId(input.requestedBy, \"Requesting member id\");\n\t\tlet requestedByHandle = handle(input.requestedByHandle);\n\t\tthis.#requireDefinition(\"research-evidence\");\n\t\tthis.#requireDefinition(\"research-answer\");\n\t\tawait input.beforeStart?.();\n\t\tlet requestFingerprint = fingerprint(\"research-inline\", {\n\t\t\tchannelId,\n\t\t\tquestion,\n\t\t\trequestedBy,\n\t\t\trequestedByHandle: requestedByHandle ?? null,\n\t\t});\n\t\tlet stored = await this.#storage.research.start({\n\t\t\tid: this.#newId(\"Workspace id\"),\n\t\t\tchannelId,\n\t\t\ttitle: researchWorkspaceTitle(question),\n\t\t\tquestion,\n\t\t\tcreatedBy: requestedBy,\n\t\t\t...(requestedByHandle ? { createdByHandle: requestedByHandle } : {}),\n\t\t\tturnId: this.#newId(\"Turn id\"),\n\t\t\tmessageId: this.#newId(\"Message id\"),\n\t\t\trequestId: durableRequestId,\n\t\t\tidempotencyKey: `research-inline:${digest(durableRequestId).slice(0, 48)}`,\n\t\t\tfingerprint: requestFingerprint,\n\t\t\tnow: this.#time(),\n\t\t\tlease: this.#lease(),\n\t\t});\n\t\tif (!stored.repeated) await this.#published(stored.workspace);\n\t\tawait this.#ensureEvidence(stored.workspace, stored.turn);\n\t\tlet request = await this.request(channelId, stored.workspace.id);\n\t\tif (!request) throw new ResearchWorkspaceError(\"not-found\", \"Research request not found.\");\n\t\treturn { request, repeated: stored.repeated };\n\t}\n\n\tasync createDraft(input: CreateResearchDraft): Promise {\n\t\tlet channelId = safeId(input.channelId, \"Channel id\");\n\t\tlet createdBy = opaqueId(input.createdBy, \"Creating member id\");\n\t\tlet proposedQuestion = normalizeResearchPrompt(input.question);\n\t\tlet scope: string;\n\t\tlet originMessageId: string | undefined;\n\t\tif (input.origin === \"sidebar\") {\n\t\t\tif (input.originMessageId !== undefined) {\n\t\t\t\tthrow new ResearchWorkspaceError(\n\t\t\t\t\t\"invalid-request\",\n\t\t\t\t\t\"Sidebar drafts cannot have an origin message.\",\n\t\t\t\t);\n\t\t\t}\n\t\t\tscope = requestId(input.requestId);\n\t\t} else if (input.origin === \"planner\") {\n\t\t\tif (input.requestId !== undefined) requestId(input.requestId);\n\t\t\toriginMessageId = safeId(\n\t\t\t\tinput.originMessageId,\n\t\t\t\t\"Origin message id\",\n\t\t\t\tMAX_ORIGIN_MESSAGE_ID,\n\t\t\t);\n\t\t\tscope = originMessageId;\n\t\t} else {\n\t\t\tthrow new ResearchWorkspaceError(\"invalid-request\", \"Research draft origin is invalid.\");\n\t\t}\n\n\t\tlet stored = await this.#storage.research.create({\n\t\t\tid: this.#newId(\"Workspace id\"),\n\t\t\tchannelId,\n\t\t\ttitle: researchWorkspaceTitle(proposedQuestion),\n\t\t\tproposedQuestion,\n\t\t\torigin: input.origin,\n\t\t\t...(originMessageId ? { originMessageId } : {}),\n\t\t\tcreatedBy,\n\t\t\tidempotencyKey: `research-draft:${input.origin}:${digest(scope).slice(0, 48)}`,\n\t\t\tfingerprint: fingerprint(\"research-draft\", {\n\t\t\t\tchannelId,\n\t\t\t\tproposedQuestion,\n\t\t\t\torigin: input.origin,\n\t\t\t\toriginMessageId: originMessageId ?? null,\n\t\t\t\tcreatedBy,\n\t\t\t}),\n\t\t\tnow: this.#time(),\n\t\t\tlease: this.#lease(),\n\t\t});\n\t\tif (!stored.repeated) await this.#published(stored.workspace);\n\t\treturn { workspace: summary(stored.workspace), repeated: stored.repeated };\n\t}\n\n\tasync confirm(input: ConfirmResearchDraft): Promise {\n\t\tlet channelId = safeId(input.channelId, \"Channel id\");\n\t\tlet workspaceId = safeId(input.workspaceId, \"Workspace id\");\n\t\tlet query = normalizeResearchPrompt(input.query);\n\t\tlet durableRequestId = requestId(input.requestId);\n\t\tlet confirmedBy = opaqueId(input.confirmedBy, \"Confirming member id\");\n\t\tlet confirmedByHandle = handle(input.confirmedByHandle);\n\t\tlet requestFingerprint = fingerprint(\"research-confirm\", {\n\t\t\tworkspaceId,\n\t\t\tquery,\n\t\t\tconfirmedBy,\n\t\t\tconfirmedByHandle: confirmedByHandle ?? null,\n\t\t});\n\n\t\treturn this.#exclusive(channelId, workspaceId, async () => {\n\t\t\tlet current = await this.#storage.research.get(channelId, workspaceId);\n\t\t\tif (!current) {\n\t\t\t\tthrow new ResearchWorkspaceError(\"not-found\", \"Research workspace not found.\");\n\t\t\t}\n\t\t\tlet repeated = current.turns.some(value => value.requestId === durableRequestId);\n\t\t\tif (!repeated) {\n\t\t\t\tif (current.workspace.confirmedQuery !== undefined) {\n\t\t\t\t\tthrow new ResearchWorkspaceError(\"not-ready\", \"Research workspace is already confirmed.\");\n\t\t\t\t}\n\t\t\t\tthis.#requireDefinition(\"research-evidence\");\n\t\t\t\tthis.#requireDefinition(\"research-answer\");\n\t\t\t\tawait input.beforeStart?.();\n\t\t\t}\n\t\t\tlet stored = await this.#storage.research.confirm({\n\t\t\t\tchannelId,\n\t\t\t\tworkspaceId,\n\t\t\t\tturnId: this.#newId(\"Turn id\"),\n\t\t\t\tmessageId: this.#newId(\"Message id\"),\n\t\t\t\trequestId: durableRequestId,\n\t\t\t\tfingerprint: requestFingerprint,\n\t\t\t\tconfirmedQuery: query,\n\t\t\t\tconfirmedBy,\n\t\t\t\t...(confirmedByHandle ? { confirmedByHandle } : {}),\n\t\t\t\tnow: this.#time(),\n\t\t\t\tlease: this.#lease(),\n\t\t\t});\n\t\t\tif (!stored.repeated) await this.#published(stored.workspace);\n\t\t\tif (this.#hasDefinition(\"research-evidence\")) {\n\t\t\t\tawait this.#ensureEvidence(stored.workspace, stored.turn);\n\t\t\t}\n\t\t\treturn this.#requiredView(channelId, workspaceId);\n\t\t});\n\t}\n\n\tasync appendTurn(input: AppendResearchWorkspaceTurn): Promise {\n\t\tlet channelId = safeId(input.channelId, \"Channel id\");\n\t\tlet workspaceId = safeId(input.workspaceId, \"Workspace id\");\n\t\tif (input.kind !== \"follow-up\" && input.kind !== \"search-more\") {\n\t\t\tthrow new ResearchWorkspaceError(\"invalid-request\", \"Research turn kind is invalid.\");\n\t\t}\n\t\tlet question = normalizeResearchPrompt(input.question);\n\t\tlet durableRequestId = requestId(input.requestId);\n\t\tlet requestedBy = opaqueId(input.requestedBy, \"Requesting member id\");\n\t\tlet requestedByHandle = handle(input.requestedByHandle);\n\t\tlet requestFingerprint = fingerprint(\"research-turn\", {\n\t\t\tworkspaceId,\n\t\t\tkind: input.kind,\n\t\t\tquestion,\n\t\t\trequestedBy,\n\t\t\trequestedByHandle: requestedByHandle ?? null,\n\t\t});\n\n\t\treturn this.#exclusive(channelId, workspaceId, async () => {\n\t\t\tlet detail = await this.#reconciled(channelId, workspaceId);\n\t\t\tif (!detail) throw new ResearchWorkspaceError(\"not-found\", \"Research workspace not found.\");\n\t\t\tlet repeated = detail.turns.some(value => value.requestId === durableRequestId);\n\t\t\tif (!repeated) {\n\t\t\t\tif (detail.workspace.confirmedQuery === undefined) {\n\t\t\t\t\tthrow new ResearchWorkspaceError(\"not-ready\", \"Research workspace is not confirmed.\");\n\t\t\t\t}\n\t\t\t\tif (!await this.#initialReport(detail)) {\n\t\t\t\t\tthrow new ResearchWorkspaceError(\n\t\t\t\t\t\t\"not-ready\",\n\t\t\t\t\t\t\"The initial research report is not ready.\",\n\t\t\t\t\t);\n\t\t\t\t}\n\t\t\t\tif (detail.turns.length >= MAX_TURNS) {\n\t\t\t\t\tthrow new ResearchWorkspaceError(\"invalid-state\", \"Research workspace is full.\");\n\t\t\t\t}\n\t\t\t\tif (await this.#hasActiveTurn(detail)) {\n\t\t\t\t\tthrow new ResearchWorkspaceError(\n\t\t\t\t\t\t\"active-turn\",\n\t\t\t\t\t\t\"Another research turn is still active.\",\n\t\t\t\t\t);\n\t\t\t\t}\n\t\t\t\tif (input.kind === \"search-more\") this.#requireDefinition(\"research-evidence\");\n\t\t\t\tthis.#requireDefinition(\"research-answer\");\n\t\t\t\tawait input.beforeStart?.();\n\t\t\t}\n\n\t\t\tlet stored = await this.#storage.research.appendTurn({\n\t\t\t\tchannelId,\n\t\t\t\tworkspaceId,\n\t\t\t\tturnId: this.#newId(\"Turn id\"),\n\t\t\t\tmessageId: this.#newId(\"Message id\"),\n\t\t\t\tkind: input.kind,\n\t\t\t\trequestId: durableRequestId,\n\t\t\t\tfingerprint: requestFingerprint,\n\t\t\t\tquestion,\n\t\t\t\trequestedBy,\n\t\t\t\t...(requestedByHandle ? { requestedByHandle } : {}),\n\t\t\t\tnow: this.#time(),\n\t\t\t\tlease: this.#lease(),\n\t\t\t});\n\t\t\tif (!stored.repeated) await this.#published(stored.workspace);\n\t\t\tif (stored.turn.kind === \"search-more\") {\n\t\t\t\tif (this.#hasDefinition(\"research-evidence\")) {\n\t\t\t\t\tawait this.#ensureEvidence(stored.workspace, stored.turn);\n\t\t\t\t}\n\t\t\t} else if (this.#hasDefinition(\"research-answer\")) {\n\t\t\t\tlet reloaded = await this.#stored(channelId, workspaceId);\n\t\t\t\tawait this.#ensureAnswer(reloaded, stored.turn);\n\t\t\t}\n\t\t\treturn this.#requiredView(channelId, workspaceId);\n\t\t});\n\t}\n\n\tasync get(channelId: string, workspaceId: string): Promise {\n\t\tif (!this.#validId(channelId) || !this.#validId(workspaceId)) return undefined;\n\t\treturn this.#exclusive(channelId, workspaceId, async () => {\n\t\t\tlet detail = await this.#reconciled(channelId, workspaceId);\n\t\t\treturn detail && this.#browserView(detail);\n\t\t});\n\t}\n\n\tasync request(channelId: string, workspaceId: string): Promise {\n\t\tif (!this.#validId(channelId) || !this.#validId(workspaceId)) return undefined;\n\t\treturn this.#exclusive(channelId, workspaceId, async () => {\n\t\t\tlet detail = await this.#reconciled(channelId, workspaceId);\n\t\t\treturn detail && this.#requestView(detail);\n\t\t});\n\t}\n\n\tread(channelId: string, workspaceId: string): Promise {\n\t\treturn this.get(channelId, workspaceId);\n\t}\n\n\tasync list(channelId: string, limit = 100): Promise {\n\t\tsafeId(channelId, \"Channel id\");\n\t\tif (!Number.isSafeInteger(limit) || limit < 1 || limit > 100) {\n\t\t\tthrow new ResearchWorkspaceError(\"invalid-request\", \"Research workspace limit is invalid.\");\n\t\t}\n\t\treturn (await this.#storage.research.list(channelId, limit)).map(summary);\n\t}\n\n\tasync listRepository(\n\t\trepositoryId: string,\n\t\tlimit = RESEARCH_REPOSITORY_WORKSPACE_LIMIT,\n\t\tincludeArchived = false,\n\t): Promise {\n\t\topaqueId(repositoryId, \"Repository id\");\n\t\tif (\n\t\t\t!Number.isSafeInteger(limit) || limit < 1\n\t\t\t|| limit > RESEARCH_REPOSITORY_WORKSPACE_LIMIT\n\t\t) {\n\t\t\tthrow new ResearchWorkspaceError(\"invalid-request\", \"Repository listing limit is invalid.\");\n\t\t}\n\t\tlet listed = await this.#storage.research.listRepository(\n\t\t\trepositoryId,\n\t\t\tlimit,\n\t\t\tincludeArchived,\n\t\t);\n\t\treturn {\n\t\t\tchannels: listed.channels.map(group => ({\n\t\t\t\tchannel: group.channel,\n\t\t\t\tworkspaces: group.workspaces.map(summary),\n\t\t\t})),\n\t\t\ttruncated: listed.truncated,\n\t\t};\n\t}\n\n\tasync cancelTurn(input: CancelResearchWorkspaceTurn): Promise {\n\t\tlet channelId = safeId(input.channelId, \"Channel id\");\n\t\tlet workspaceId = safeId(input.workspaceId, \"Workspace id\");\n\t\tlet turnId = safeId(input.turnId, \"Turn id\");\n\t\treturn this.#exclusive(channelId, workspaceId, async () => {\n\t\t\tlet detail = await this.#reconciled(channelId, workspaceId);\n\t\t\tif (!detail) throw new ResearchWorkspaceError(\"not-found\", \"Research workspace not found.\");\n\t\t\tlet found = detail.turns.find(value => value.id === turnId);\n\t\t\tif (!found) throw new ResearchWorkspaceError(\"not-found\", \"Research turn not found.\");\n\t\t\tawait this.#cancelActiveTurn(detail, found);\n\t\t\treturn this.#requiredView(channelId, workspaceId);\n\t\t});\n\t}\n\n\tasync cancelRequest(input: CancelResearchRequest): Promise {\n\t\tlet channelId = safeId(input.channelId, \"Channel id\");\n\t\tlet workspaceId = safeId(input.workspaceId, \"Workspace id\");\n\t\treturn this.#exclusive(channelId, workspaceId, async () => {\n\t\t\tlet detail = await this.#reconciled(channelId, workspaceId);\n\t\t\tif (!detail) throw new ResearchWorkspaceError(\"not-found\", \"Research request not found.\");\n\t\t\tlet initial = detail.turns.find(value => value.kind === \"initial\");\n\t\t\tif (!initial) {\n\t\t\t\tthrow new ResearchWorkspaceError(\"invalid-state\", \"Research request has no initial work.\");\n\t\t\t}\n\t\t\tawait this.#cancelActiveTurn(detail, initial);\n\t\t\tlet refreshed = await this.#reconciled(channelId, workspaceId);\n\t\t\tif (!refreshed) throw new ResearchWorkspaceError(\"not-found\", \"Research request not found.\");\n\t\t\treturn this.#requestView(refreshed);\n\t\t});\n\t}\n\n\tasync #cancelActiveTurn(\n\t\tdetail: ResearchWorkspaceDetail,\n\t\tfound: ResearchTurn,\n\t): Promise {\n\t\tlet candidates = [\n\t\t\t...(found.answerJobId ? [{ id: found.answerJobId, role: \"answer\" as const }] : []),\n\t\t\t...(found.evidenceJobId\n\t\t\t\t? [{ id: found.evidenceJobId, role: \"evidence\" as const }]\n\t\t\t\t: []),\n\t\t];\n\t\tlet active: JobDetail | undefined;\n\t\tlet alreadyCancelled = false;\n\t\tfor (let candidate of candidates) {\n\t\t\tlet current = await this.#jobs.get(detail.workspace.channelId, candidate.id);\n\t\t\tif (current) this.#assertLinkedJob(current, detail.workspace, found, candidate.role);\n\t\t\tif (current?.job.state === \"cancelled\") alreadyCancelled = true;\n\t\t\tif (current && ACTIVE_JOB_STATES.has(current.job.state)) {\n\t\t\t\tactive = current;\n\t\t\t\tbreak;\n\t\t\t}\n\t\t}\n\t\tif (!active) {\n\t\t\tif (alreadyCancelled) return;\n\t\t\tthrow new ResearchWorkspaceError(\"not-ready\", \"Research turn is not cancellable.\");\n\t\t}\n\t\tawait this.#jobs.cancel({ channelId: detail.workspace.channelId, jobId: active.job.id });\n\t\tawait this.#published(detail.workspace);\n\t}\n\n\tasync jobChanged(job: JobView): Promise {\n\t\tif (\n\t\t\tjob.state !== \"completed\"\n\t\t\t|| (job.type !== \"research-evidence\" && job.type !== \"research-answer\")\n\t\t\t|| !this.#validId(job.channelId)\n\t\t) return;\n\t\tlet linked = await this.#storage.research.findTurnByJob(job.channelId, job.id);\n\t\tif (!linked) return;\n\t\tawait this.#exclusive(job.channelId, linked.workspaceId, async () => {\n\t\t\tawait this.#reconciled(job.channelId, linked.workspaceId);\n\t\t});\n\t}\n\n\tasync #requiredView(channelId: string, workspaceId: string): Promise {\n\t\tlet detail = await this.#reconciled(channelId, workspaceId);\n\t\tif (!detail) throw new ResearchWorkspaceError(\"not-found\", \"Research workspace not found.\");\n\t\treturn this.#browserView(detail);\n\t}\n\n\tasync #reconciled(\n\t\tchannelId: string,\n\t\tworkspaceId: string,\n\t): Promise {\n\t\tlet maximum = MAX_TURNS * 3 + 1;\n\t\tfor (let pass = 0; pass < maximum; pass++) {\n\t\t\tlet detail = await this.#storage.research.get(channelId, workspaceId);\n\t\t\tif (!detail) return undefined;\n\t\t\tif (detail.turns.length > MAX_TURNS) {\n\t\t\t\tthrow new ResearchWorkspaceError(\"invalid-state\", \"Research workspace is too large.\");\n\t\t\t}\n\t\t\tlet changed = false;\n\t\t\tfor (let savedTurn of detail.turns) {\n\t\t\t\tif (\n\t\t\t\t\t(savedTurn.kind === \"initial\" || savedTurn.kind === \"search-more\")\n\t\t\t\t\t&& savedTurn.evidenceJobId === undefined\n\t\t\t\t\t&& this.#hasDefinition(\"research-evidence\")\n\t\t\t\t) {\n\t\t\t\t\tchanged = await this.#ensureEvidence(detail.workspace, savedTurn);\n\t\t\t\t\tif (changed) break;\n\t\t\t\t}\n\t\t\t\tif (savedTurn.evidenceJobId && savedTurn.answerJobId === undefined) {\n\t\t\t\t\tlet evidence = await this.#jobs.get(channelId, savedTurn.evidenceJobId);\n\t\t\t\t\tif (evidence?.job.state === \"completed\" && this.#hasDefinition(\"research-answer\")) {\n\t\t\t\t\t\tchanged = await this.#ensureAnswer(detail, savedTurn);\n\t\t\t\t\t\tif (changed) break;\n\t\t\t\t\t}\n\t\t\t\t}\n\t\t\t\tif (\n\t\t\t\t\tsavedTurn.kind === \"follow-up\" && savedTurn.answerJobId === undefined\n\t\t\t\t\t&& this.#hasDefinition(\"research-answer\")\n\t\t\t\t) {\n\t\t\t\t\tif (await this.#initialReport(detail)) {\n\t\t\t\t\t\tchanged = await this.#ensureAnswer(detail, savedTurn);\n\t\t\t\t\t\tif (changed) break;\n\t\t\t\t\t}\n\t\t\t\t}\n\t\t\t\tif (savedTurn.answerJobId) {\n\t\t\t\t\tlet answer = await this.#jobs.get(channelId, savedTurn.answerJobId);\n\t\t\t\t\tif (\n\t\t\t\t\t\tsavedTurn.kind === \"initial\" && answer?.job.state === \"completed\"\n\t\t\t\t\t\t&& detail.workspace.publishedChannelId === undefined\n\t\t\t\t\t) {\n\t\t\t\t\t\tchanged = await this.#publishInitialReport(detail, savedTurn, answer);\n\t\t\t\t\t\tif (changed) break;\n\t\t\t\t\t}\n\t\t\t\t\tlet alreadyAppended = detail.messages.some(value =>\n\t\t\t\t\t\tvalue.authorKind === \"agent\"\n\t\t\t\t\t\t&& value.turnId === savedTurn.id\n\t\t\t\t\t\t&& value.sourceJobId === savedTurn.answerJobId\n\t\t\t\t\t);\n\t\t\t\t\tif (answer?.job.state === \"completed\" && !alreadyAppended) {\n\t\t\t\t\t\tchanged = await this.#appendCompletedAnswer(detail, savedTurn, answer);\n\t\t\t\t\t\tif (changed) break;\n\t\t\t\t\t}\n\t\t\t\t}\n\t\t\t}\n\t\t\tif (!changed) return detail;\n\t\t}\n\t\tthrow new ResearchWorkspaceError(\"invalid-state\", \"Research reconciliation did not converge.\");\n\t}\n\n\tasync #publishInitialReport(\n\t\tdetail: ResearchWorkspaceDetail,\n\t\tsavedTurn: ResearchTurn,\n\t\tjob: JobDetail,\n\t): Promise {\n\t\tlet artifact = this.#answerArtifact(job, detail.workspace, savedTurn);\n\t\tif (artifact.kind !== \"initial\") {\n\t\t\tthrow new ResearchWorkspaceError(\"invalid-state\", \"Initial research report is invalid.\");\n\t\t}\n\t\tlet initial = await Plan.initial(researchReportSource(artifact.report, artifact.sources));\n\t\tlet published = await this.#storage.research.publishInitialReport({\n\t\t\tchannelId: detail.workspace.channelId,\n\t\t\tworkspaceId: detail.workspace.id,\n\t\t\tanswerJobId: job.job.id,\n\t\t\ttitle: await this.#publicationTitle(\n\t\t\t\tdetail.workspace.channelId,\n\t\t\t\tresearchWorkspaceTitle(artifact.report.title),\n\t\t\t),\n\t\t\tinitial,\n\t\t\tnow: this.#time(),\n\t\t\tlease: this.#lease(),\n\t\t});\n\t\tif (!published.repeated) await this.#published(published.workspace);\n\t\treturn true;\n\t}\n\n\tasync #publicationTitle(channelId: string, requested: string): Promise {\n\t\tlet parent = await this.#storage.channels.get(channelId);\n\t\tif (!parent) {\n\t\t\tthrow new ResearchWorkspaceError(\"not-ready\", \"The parent document is unavailable.\");\n\t\t}\n\t\tlet titles = new Set();\n\t\tlet after: { updatedAt: Date; id: string } | undefined;\n\t\tdo {\n\t\t\tlet page = await this.#storage.channels.list(\n\t\t\t\tparent.repositoryId,\n\t\t\t\t100,\n\t\t\t\tafter,\n\t\t\t\tundefined,\n\t\t\t\ttrue,\n\t\t\t);\n\t\t\tfor (let channel of page.channels) titles.add(channel.title.toLowerCase());\n\t\t\tafter = page.next;\n\t\t} while (after);\n\t\tif (!titles.has(requested.toLowerCase())) return requested;\n\t\tfor (let index = 2; index <= titles.size + 2; index++) {\n\t\t\tlet candidate = suffixedResearchTitle(requested, ` (${index})`);\n\t\t\tif (!titles.has(candidate.toLowerCase())) return candidate;\n\t\t}\n\t\tthrow new ResearchWorkspaceError(\"invalid-state\", \"A research child title is unavailable.\");\n\t}\n\n\tasync #ensureEvidence(workspace: ResearchWorkspace, savedTurn: ResearchTurn): Promise {\n\t\tif (savedTurn.evidenceJobId !== undefined) return false;\n\t\tthis.#requireDefinition(\"research-evidence\");\n\t\tlet targetKey = this.#target(workspace.id, savedTurn.id, \"evidence\");\n\t\tlet existing = await this.#targetJob(workspace.channelId, \"research-evidence\", targetKey);\n\t\tlet job = existing ?? (await this.#jobs.enqueueUser({\n\t\t\tchannelId: workspace.channelId,\n\t\t\ttype: \"research-evidence\",\n\t\t\ttargetKey,\n\t\t\tidempotencyKey: `research-evidence:${savedTurn.id}`,\n\t\t\tinput: {\n\t\t\t\tworkspaceId: workspace.id,\n\t\t\t\tturnId: savedTurn.id,\n\t\t\t\tquery: savedTurn.question,\n\t\t\t},\n\t\t})).job;\n\t\tlet linked = await this.#storage.research.linkJob({\n\t\t\tchannelId: workspace.channelId,\n\t\t\tworkspaceId: workspace.id,\n\t\t\tturnId: savedTurn.id,\n\t\t\trole: \"evidence\",\n\t\t\tjobId: job.id,\n\t\t\tnow: this.#time(),\n\t\t\tlease: this.#lease(),\n\t\t});\n\t\tif (!linked.repeated) await this.#published(linked.workspace);\n\t\treturn true;\n\t}\n\n\tasync #ensureAnswer(detail: ResearchWorkspaceDetail, savedTurn: ResearchTurn): Promise {\n\t\tif (savedTurn.answerJobId !== undefined) return false;\n\t\tthis.#requireDefinition(\"research-answer\");\n\t\tlet workspace = detail.workspace;\n\t\tlet targetKey = this.#target(workspace.id, savedTurn.id, \"answer\");\n\t\tlet existing = await this.#targetJob(workspace.channelId, \"research-answer\", targetKey);\n\t\tlet job: JobView;\n\t\tif (existing) job = existing;\n\t\telse {\n\t\t\tlet input = await this.#answerInput(detail, savedTurn);\n\t\t\tlet enqueued = await this.#jobs.enqueueUser({\n\t\t\t\tchannelId: workspace.channelId,\n\t\t\t\ttype: \"research-answer\",\n\t\t\t\ttargetKey,\n\t\t\t\tidempotencyKey: `research-answer:${savedTurn.id}`,\n\t\t\t\tinput: input as JsonValue,\n\t\t\t});\n\t\t\tjob = enqueued.job;\n\t\t}\n\t\tlet linked = await this.#storage.research.linkJob({\n\t\t\tchannelId: workspace.channelId,\n\t\t\tworkspaceId: workspace.id,\n\t\t\tturnId: savedTurn.id,\n\t\t\trole: \"answer\",\n\t\t\tjobId: job.id,\n\t\t\tnow: this.#time(),\n\t\t\tlease: this.#lease(),\n\t\t});\n\t\tif (!linked.repeated) await this.#published(linked.workspace);\n\t\treturn true;\n\t}\n\n\tasync #answerInput(\n\t\tdetail: ResearchWorkspaceDetail,\n\t\tsavedTurn: ResearchTurn,\n\t): Promise {\n\t\tlet document = await this.#current(detail.workspace.channelId);\n\t\tif (!document || document.channelId !== detail.workspace.channelId) {\n\t\t\tthrow new ResearchWorkspaceError(\"not-ready\", \"The parent document is not available.\");\n\t\t}\n\t\tlet evidence = await this.#committedEvidence(detail);\n\t\tlet history = this.#history(detail.messages);\n\t\tlet base = {\n\t\t\tworkspaceId: detail.workspace.id,\n\t\t\tturnId: savedTurn.id,\n\t\t\tquestion: savedTurn.question,\n\t\t\tdocument: {\n\t\t\t\tsource: document.source,\n\t\t\t\trevision: document.revision,\n\t\t\t\tsourceHash: document.sourceHash,\n\t\t\t},\n\t\t\tevidence,\n\t\t\thistory,\n\t\t};\n\t\tlet input: JsonValue;\n\t\tif (savedTurn.kind === \"initial\") input = { ...base, kind: \"initial\" } as JsonValue;\n\t\telse {\n\t\t\tlet originalReport = await this.#initialReport(detail);\n\t\t\tif (!originalReport) {\n\t\t\t\tthrow new ResearchWorkspaceError(\"not-ready\", \"The initial research report is not ready.\");\n\t\t\t}\n\t\t\tinput = {\n\t\t\t\t...base,\n\t\t\t\tkind: savedTurn.kind,\n\t\t\t\toriginalReport: structuredClone(originalReport),\n\t\t\t} as JsonValue;\n\t\t}\n\t\ttry {\n\t\t\treturn parseResearchAnswerInput(input);\n\t\t} catch (err) {\n\t\t\tthrow new ResearchWorkspaceError(\n\t\t\t\t\"invalid-state\",\n\t\t\t\t\"Research answer material is invalid.\",\n\t\t\t\t{ cause: err },\n\t\t\t);\n\t\t}\n\t}\n\n\tasync #committedEvidence(detail: ResearchWorkspaceDetail): Promise {\n\t\tlet evidence: ResearchEvidence[] = [];\n\t\tfor (let savedTurn of detail.turns) {\n\t\t\tif (!savedTurn.evidenceJobId) continue;\n\t\t\tlet job = await this.#jobs.get(detail.workspace.channelId, savedTurn.evidenceJobId);\n\t\t\tif (!job || job.job.type !== \"research-evidence\") {\n\t\t\t\tthrow new ResearchWorkspaceError(\"invalid-state\", \"Linked research evidence is missing.\");\n\t\t\t}\n\t\t\tif (job.job.state !== \"completed\") continue;\n\t\t\tlet artifact = this.#evidenceArtifact(job, detail.workspace, savedTurn);\n\t\t\tevidence.push({\n\t\t\t\tfindings: [...artifact.findings],\n\t\t\t\tsources: artifact.sources.map(value => ({ ...value })),\n\t\t\t});\n\t\t}\n\t\treturn boundedResearchEvidence(evidence);\n\t}\n\n\tasync #initialReport(detail: ResearchWorkspaceDetail): Promise {\n\t\tlet initial = detail.turns.find(value => value.kind === \"initial\");\n\t\tif (!initial?.answerJobId) return undefined;\n\t\tlet job = await this.#jobs.get(detail.workspace.channelId, initial.answerJobId);\n\t\tif (!job || job.job.type !== \"research-answer\" || job.job.state !== \"completed\") {\n\t\t\treturn undefined;\n\t\t}\n\t\tlet artifact = this.#answerArtifact(job, detail.workspace, initial);\n\t\treturn artifact.kind === \"initial\" ? structuredClone(artifact.report) : undefined;\n\t}\n\n\t#history(messages: ResearchMessage[]): Array<{ author: \"member\" | \"agent\"; text: string }> {\n\t\tlet candidates = messages.filter(\n\t\t\t(value): value is ResearchMessage & { authorKind: \"member\" | \"agent\" } =>\n\t\t\t\tvalue.authorKind === \"member\" || value.authorKind === \"agent\",\n\t\t).slice(-MAX_HISTORY);\n\t\tlet history: Array<{ author: \"member\" | \"agent\"; text: string }> = [];\n\t\tlet remaining = MAX_HISTORY_BYTES;\n\t\tfor (let value of candidates.toReversed()) {\n\t\t\tlet text = boundedHistoryText(value.text, remaining);\n\t\t\tif (!text) break;\n\t\t\thistory.push({ author: value.authorKind, text });\n\t\t\tremaining -= Buffer.byteLength(text);\n\t\t\tif (remaining <= 0) break;\n\t\t}\n\t\treturn history.toReversed();\n\t}\n\n\tasync #appendCompletedAnswer(\n\t\tdetail: ResearchWorkspaceDetail,\n\t\tsavedTurn: ResearchTurn,\n\t\tjob: JobDetail,\n\t): Promise {\n\t\tlet artifact = this.#answerArtifact(job, detail.workspace, savedTurn);\n\t\tlet text = artifact.kind === \"initial\" ? artifact.report.summary : artifact.answer.text;\n\t\tlet stored = await this.#storage.research.appendAgentMessage({\n\t\t\tchannelId: detail.workspace.channelId,\n\t\t\tworkspaceId: detail.workspace.id,\n\t\t\tid: `research-answer-${digest(job.job.id).slice(0, 32)}`,\n\t\t\tturnId: savedTurn.id,\n\t\t\ttext,\n\t\t\tsourceJobId: job.job.id,\n\t\t\tnow: this.#time(),\n\t\t\tlease: this.#lease(),\n\t\t});\n\t\tif (!stored.repeated) await this.#published(stored.workspace);\n\t\treturn true;\n\t}\n\n\t#evidenceArtifact(job: JobDetail, workspace: ResearchWorkspace, savedTurn: ResearchTurn) {\n\t\tthis.#assertLinkedJob(job, workspace, savedTurn, \"evidence\");\n\t\tif (!job.artifact || job.job.targetGeneration !== job.target.generation) {\n\t\t\tthrow new ResearchWorkspaceError(\"invalid-state\", \"Research evidence artifact is missing.\");\n\t\t}\n\t\ttry {\n\t\t\tlet artifact = parseResearchEvidenceArtifact(job.artifact.value);\n\t\t\tif (\n\t\t\t\tartifact.workspaceId !== workspace.id || artifact.turnId !== savedTurn.id\n\t\t\t\t|| artifact.query !== savedTurn.question\n\t\t\t) throw new Error(\"artifact target does not match\");\n\t\t\treturn artifact;\n\t\t} catch (err) {\n\t\t\tthrow new ResearchWorkspaceError(\n\t\t\t\t\"invalid-state\",\n\t\t\t\t\"Research evidence artifact is invalid.\",\n\t\t\t\t{ cause: err },\n\t\t\t);\n\t\t}\n\t}\n\n\t#answerArtifact(job: JobDetail, workspace: ResearchWorkspace, savedTurn: ResearchTurn) {\n\t\tthis.#assertLinkedJob(job, workspace, savedTurn, \"answer\");\n\t\tif (!job.artifact || job.job.targetGeneration !== job.target.generation) {\n\t\t\tthrow new ResearchWorkspaceError(\"invalid-state\", \"Research answer artifact is missing.\");\n\t\t}\n\t\ttry {\n\t\t\tlet artifact = parseResearchAnswerArtifact(job.artifact.value);\n\t\t\tif (\n\t\t\t\tartifact.workspaceId !== workspace.id || artifact.turnId !== savedTurn.id\n\t\t\t\t|| artifact.kind !== savedTurn.kind\n\t\t\t) throw new Error(\"artifact target does not match\");\n\t\t\treturn artifact;\n\t\t} catch (err) {\n\t\t\tthrow new ResearchWorkspaceError(\n\t\t\t\t\"invalid-state\",\n\t\t\t\t\"Research answer artifact is invalid.\",\n\t\t\t\t{ cause: err },\n\t\t\t);\n\t\t}\n\t}\n\n\tasync #hasActiveTurn(detail: ResearchWorkspaceDetail): Promise {\n\t\tfor (let savedTurn of detail.turns) {\n\t\t\tif (\n\t\t\t\tdetail.messages.some(value => value.authorKind === \"agent\" && value.turnId === savedTurn.id)\n\t\t\t) {\n\t\t\t\tcontinue;\n\t\t\t}\n\t\t\tlet jobId = savedTurn.answerJobId ?? savedTurn.evidenceJobId;\n\t\t\tif (!jobId) return true;\n\t\t\tlet job = await this.#jobs.get(detail.workspace.channelId, jobId);\n\t\t\tif (!job) {\n\t\t\t\tthrow new ResearchWorkspaceError(\"invalid-state\", \"Linked research work is missing.\");\n\t\t\t}\n\t\t\tif (ACTIVE_JOB_STATES.has(job.job.state)) return true;\n\t\t}\n\t\treturn false;\n\t}\n\n\tasync #browserView(detail: ResearchWorkspaceDetail): Promise {\n\t\tlet turns: ResearchWorkspaceTurnView[] = [];\n\t\tfor (let savedTurn of detail.turns) {\n\t\t\tlet evidence = savedTurn.evidenceJobId\n\t\t\t\t? await this.#browserJob(detail.workspace, savedTurn, savedTurn.evidenceJobId, \"evidence\")\n\t\t\t\t: undefined;\n\t\t\tlet answer = savedTurn.answerJobId\n\t\t\t\t? await this.#browserJob(detail.workspace, savedTurn, savedTurn.answerJobId, \"answer\")\n\t\t\t\t: undefined;\n\t\t\tturns.push({\n\t\t\t\t...turn(savedTurn),\n\t\t\t\t...(evidence ? { evidence } : {}),\n\t\t\t\t...(answer ? { answer } : {}),\n\t\t\t});\n\t\t}\n\t\treturn {\n\t\t\tworkspace: summary(detail.workspace),\n\t\t\tturns,\n\t\t\tmessages: detail.messages.map(message),\n\t\t};\n\t}\n\n\tasync #requestView(detail: ResearchWorkspaceDetail): Promise {\n\t\tlet savedTurn = detail.turns.find(value => value.kind === \"initial\");\n\t\tif (!savedTurn) {\n\t\t\tthrow new ResearchWorkspaceError(\"invalid-state\", \"Research request has no initial work.\");\n\t\t}\n\t\tlet evidence = savedTurn.evidenceJobId\n\t\t\t? await this.#jobs.get(detail.workspace.channelId, savedTurn.evidenceJobId)\n\t\t\t: undefined;\n\t\tlet answer = savedTurn.answerJobId\n\t\t\t? await this.#jobs.get(detail.workspace.channelId, savedTurn.answerJobId)\n\t\t\t: undefined;\n\t\tif (evidence) this.#assertLinkedJob(evidence, detail.workspace, savedTurn, \"evidence\");\n\t\tif (answer) this.#assertLinkedJob(answer, detail.workspace, savedTurn, \"answer\");\n\t\tlet sources: ResearchEvidence[\"sources\"] = [];\n\t\tif (evidence?.job.state === \"completed\") {\n\t\t\tsources = this.#evidenceArtifact(evidence, detail.workspace, savedTurn).sources;\n\t\t}\n\t\tlet state: Research.RequestState = answer?.job.state ?? evidence?.job.state ?? \"pending\";\n\t\tlet stage: Research.RequestStage = \"queued\";\n\t\tlet error: string | undefined;\n\t\tif (state === \"failed\") {\n\t\t\tstage = \"failed\";\n\t\t\terror = \"Research could not be completed.\";\n\t\t} else if (state === \"cancelled\" || state === \"superseded\") {\n\t\t\tstage = \"cancelled\";\n\t\t} else if (detail.workspace.publishedChannelId) stage = \"ready\";\n\t\telse if (answer?.job.state === \"completed\") stage = \"publishing\";\n\t\telse if (answer) {\n\t\t\tstage = answer.job.progress.some(value =>\n\t\t\t\t\tvalue.stage === \"report-synthesis\" && value.state === \"started\"\n\t\t\t\t)\n\t\t\t\t? \"writing\"\n\t\t\t\t: \"analyzing\";\n\t\t} else if (\n\t\t\tevidence?.job.progress.some(value =>\n\t\t\t\tvalue.stage === \"public-web\" && value.state === \"started\"\n\t\t\t)\n\t\t) stage = \"searching\";\n\t\tlet child: Research.ReadyChild | undefined;\n\t\tif (detail.workspace.publishedChannelId) {\n\t\t\tlet channel = await this.#storage.channels.get(detail.workspace.publishedChannelId);\n\t\t\tlet report = await this.#initialReport(detail);\n\t\t\tif (!channel || !report) {\n\t\t\t\tthrow new ResearchWorkspaceError(\"invalid-state\", \"Published research child is invalid.\");\n\t\t\t}\n\t\t\tchild = {\n\t\t\t\tid: channel.id,\n\t\t\t\ttitle: channel.title,\n\t\t\t\tslug: channel.slug,\n\t\t\t\tsummary: report.summary,\n\t\t\t\tsourceCount: sources.length,\n\t\t\t};\n\t\t}\n\t\treturn {\n\t\t\tid: detail.workspace.id,\n\t\t\tchannelId: detail.workspace.channelId,\n\t\t\tquestion: savedTurn.question,\n\t\t\tstate,\n\t\t\tstage,\n\t\t\t...(error ? { error } : {}),\n\t\t\tsources: sources.map(value => ({ ...value })),\n\t\t\t...(child ? { child } : {}),\n\t\t\tcreatedAt: detail.workspace.createdAt.toISOString(),\n\t\t\tupdatedAt: detail.workspace.updatedAt.toISOString(),\n\t\t};\n\t}\n\n\tasync #browserJob(\n\t\tworkspace: ResearchWorkspace,\n\t\tsavedTurn: ResearchTurn,\n\t\tjobId: string,\n\t\trole: \"evidence\" | \"answer\",\n\t): Promise {\n\t\tlet job = await this.#jobs.get(workspace.channelId, jobId);\n\t\tif (!job) {\n\t\t\tthrow new ResearchWorkspaceError(\"invalid-state\", `Linked research ${role} is missing.`);\n\t\t}\n\t\tthis.#assertLinkedJob(job, workspace, savedTurn, role);\n\t\tif (job.artifact) {\n\t\t\tlet value = role === \"evidence\"\n\t\t\t\t? this.#evidenceArtifact(job, workspace, savedTurn)\n\t\t\t\t: this.#answerArtifact(job, workspace, savedTurn);\n\t\t\tjob = { ...job, artifact: { ...job.artifact, value: value as JsonValue } };\n\t\t}\n\t\treturn serializedJobDetail(job);\n\t}\n\n\tasync #targetJob(\n\t\tchannelId: string,\n\t\ttype: \"research-evidence\" | \"research-answer\",\n\t\ttargetKey: string,\n\t): Promise {\n\t\tlet expected = `${type}:${targetKey}`;\n\t\tlet cursor;\n\t\tlet scanned = 0;\n\t\tlet selected: JobView | undefined;\n\t\tdo {\n\t\t\tlet page = await this.#jobs.list(channelId, 100, cursor);\n\t\t\tif (!page) return undefined;\n\t\t\tfor (let job of page.jobs) {\n\t\t\t\tscanned++;\n\t\t\t\tif (\n\t\t\t\t\tjob.type === type && job.targetKey === expected\n\t\t\t\t\t&& (!selected || job.targetGeneration > selected.targetGeneration)\n\t\t\t\t) selected = job;\n\t\t\t\tif (scanned >= MAX_TARGET_SCAN) break;\n\t\t\t}\n\t\t\tif (selected || scanned >= MAX_TARGET_SCAN) break;\n\t\t\tcursor = page.next;\n\t\t} while (cursor);\n\t\treturn selected;\n\t}\n\n\t#target(workspaceId: string, turnId: string, role: \"evidence\" | \"answer\"): string {\n\t\treturn `workspace:${workspaceId}:turn:${turnId}:${role}`;\n\t}\n\n\t#assertLinkedJob(\n\t\tjob: JobDetail,\n\t\tworkspace: ResearchWorkspace,\n\t\tsavedTurn: ResearchTurn,\n\t\trole: \"evidence\" | \"answer\",\n\t): void {\n\t\tlet type = role === \"evidence\" ? \"research-evidence\" : \"research-answer\";\n\t\tif (\n\t\t\tjob.job.channelId !== workspace.channelId || job.job.type !== type\n\t\t\t|| job.job.targetKey !== `${type}:${this.#target(workspace.id, savedTurn.id, role)}`\n\t\t) {\n\t\t\tthrow new ResearchWorkspaceError(\"invalid-state\", `Linked research ${role} is invalid.`);\n\t\t}\n\t}\n\n\tasync #stored(channelId: string, workspaceId: string): Promise {\n\t\tlet detail = await this.#storage.research.get(channelId, workspaceId);\n\t\tif (!detail) throw new ResearchWorkspaceError(\"not-found\", \"Research workspace not found.\");\n\t\treturn detail;\n\t}\n\n\t#newId(field: string): string {\n\t\treturn safeId(this.#id(), field);\n\t}\n\n\t#time(): Date {\n\t\tlet value = this.#clock();\n\t\tif (!(value instanceof Date) || Number.isNaN(value.getTime())) {\n\t\t\tthrow new Error(\"Research workspace clock returned an invalid time.\");\n\t\t}\n\t\treturn new Date(value);\n\t}\n\n\t#validId(value: string): boolean {\n\t\treturn value.length >= 1 && value.length <= MAX_ID && SAFE_ID.test(value);\n\t}\n\n\t#hasDefinition(type: \"research-evidence\" | \"research-answer\"): boolean {\n\t\treturn this.#jobs.definition(type, 1) !== undefined;\n\t}\n\n\t#requireDefinition(type: \"research-evidence\" | \"research-answer\"): void {\n\t\tif (this.#hasDefinition(type)) return;\n\t\tthrow new ResearchWorkspaceError(\"not-ready\", \"Research execution is unavailable.\");\n\t}\n\n\tasync #published(workspace: ResearchWorkspace): Promise {\n\t\ttry {\n\t\t\tawait this.#publish(workspace.channelId, workspace.id, workspace.revision);\n\t\t} catch (err) {\n\t\t\tconsole.warn(\n\t\t\t\t`[research] could not publish workspace ${workspace.id} revision ${workspace.revision}:`,\n\t\t\t\terr,\n\t\t\t);\n\t\t}\n\t}\n\n\tasync #exclusive(\n\t\tchannelId: string,\n\t\tworkspaceId: string,\n\t\taction: () => Promise,\n\t): Promise {\n\t\tlet key = `${channelId}\\0${workspaceId}`;\n\t\tlet previous = this.#tails.get(key) ?? Promise.resolve();\n\t\tlet release = Promise.withResolvers();\n\t\tlet current = previous.then(() => release.promise);\n\t\tthis.#tails.set(key, current);\n\t\tawait previous;\n\t\ttry {\n\t\t\treturn await action();\n\t\t} finally {\n\t\t\trelease.resolve();\n\t\t\tif (this.#tails.get(key) === current) this.#tails.delete(key);\n\t\t}\n\t}\n}\n","editable",false,"branch","documentNavigation","repo","githubnext/chopin","repoId","7d1a8ac3-35b0-4dea-85d4-06a980f3bada","ownerId","org:89615882","organization",true,"site","nexthub","private","admin","settings","maintainer","triage","starred","stars",0,"watchers","watching","pinned","notify","views",[184,185,186,187,188,189,190,191,192,193,194,195,196],"navigation",{"_56":57,"_141":142,"_143":144,"_145":146,"_147":148,"_149":150,"_151":152},"sources",[],"viewer","meta",{"_133":134,"_135":136,"_137":138,"_44":31,"_139":128,"_140":31,"_50":51,"_52":51},"branches",[75,76,77,78,79,80,81,82,83,84,85,86,87,88,89,90,91,92,93,94,95,96,97,98,99,100,101,102,103,104,105,106,107,108,109,110,111,112,113,114,115,116,117,118,119,120,121,122,123,124,125,126,127,128,129,130,131,132],"tags",[71,72,73,74],"cloneUrl","https://git.nexthub.sh/githubnext/chopin.git","color-controls-slice-1","color-controls-slice-2","color-controls-slice-3","color-controls-slice-4","Krzysztof-Cieslak-patch-1","Krzysztof-Cieslak-patch-2","Maggie/app-preview-toolkit","Maggie/ci-playwright-install-timeout","Maggie/collaborative-visual-decision","Maggie/design-audit","Maggie/generic-visual-decision-runtime","Maggie/impeccable-chopin-metadata","Maggie/jev-chat-product","Maggie/jev-composed-assessment","Maggie/native-document-layouts","Maggie/openui-composition-product","Maggie/openui-composition-trial","Maggie/planner-visual-authoring","Maggie/planner-visual-requests","Maggie/visual-selection-eval","artifacts/pr-419-live-preview-20261009","automation/pr-maintenance-state","automation/use-effect/callout-disabled-picker-8cf9e49ba5c09471","automation/use-effect/collaboration-options-ref-4e3a5a08a879a5ae","automation/use-effect/room-workspace-effective-access-a57d40866c71bed0","chore/bun-1.4.2","color-controls","color-controls-plan","comments","design-pr-assets","design/archived-decisions-badge","design/channel-route-remount","design/chat-decision-entry","design/conversation-analysis-markers","design/decision-evidence","design/settled-line-icon","dev/integration","diagram-step-controls","feat/liveapp-frontend-pilot","feat/local-experiments","feat/local-launcher-tracer","fix/autolink-mdx-crash","github-pills/2-pills","github-pills/3-hover-card","maggie/app-preview-toolkit","maggie/ci-playwright-install-timeout","maggie/collaborative-visual-decision","maggie/design-audit","maggie/generic-visual-decision-runtime","maggie/impeccable-chopin-metadata","maggie/jev-composed-assessment","maggie/native-document-layouts","maggie/openui-composition-product","maggie/openui-composition-trial","maggie/planner-visual-authoring","maggie/planner-visual-requests","maggie/visual-selection-eval","main","plain-text-fence-chrome","tokens/09-copy","wireframes/2-renderer","wireframes/3-planner","description","Let's compose rich plans together","owner","githubnext","section","","head","empty","pins",[167,168,169],"documents",{"_162":163,"_164":165},"code",{"_158":159,"_160":161},"automations",{"_155":156,"_157":-5},"delivery",{"_153":51,"_154":-5},"tag","04zvKQ8QOrDUF8TO1Ovz0Zy8_TT","releases","applications","workflows",3,"deployments","commits",1000,"changes",13,"counts",{"_166":165},"total",11,"issue",{"_170":160,"_172":182,"_15":160,"_174":183,"_54":41,"_176":31,"_177":41,"_178":161},{"_170":179,"_172":180,"_15":179,"_174":181,"_54":41,"_176":31,"_177":41,"_178":51},{"_170":171,"_172":173,"_15":171,"_174":175,"_54":41,"_176":31,"_177":41,"_178":165},"id","issues","name","Issues","filters",{},"saved","pinnable","count","tasks","Tasks",{},"Changes",{},{"_170":160,"_172":182,"_15":160,"_174":227,"_54":41,"_176":31,"_177":41},{"_170":179,"_172":180,"_15":179,"_174":226,"_54":41,"_176":31,"_177":41},{"_170":171,"_172":173,"_15":171,"_174":225,"_54":41,"_176":31,"_177":41},{"_170":222,"_172":223,"_15":222,"_174":224,"_54":31,"_176":31,"_177":41},{"_170":219,"_172":220,"_15":219,"_174":221,"_54":31,"_176":31,"_177":41},{"_170":155,"_172":217,"_15":147,"_174":218,"_54":31,"_176":31,"_177":41},{"_170":157,"_172":214,"_15":215,"_174":216,"_54":31,"_176":31,"_177":41},{"_170":153,"_172":212,"_15":153,"_174":213,"_54":31,"_176":31,"_177":41},{"_170":208,"_172":209,"_15":210,"_174":211,"_54":31,"_176":31,"_177":41},{"_170":143,"_172":206,"_15":143,"_174":207,"_54":31,"_176":31,"_177":31},{"_170":203,"_172":204,"_15":203,"_174":205,"_54":31,"_176":31,"_177":31},{"_170":200,"_172":201,"_15":200,"_174":202,"_54":31,"_176":31,"_177":31},{"_170":197,"_172":198,"_15":197,"_174":199,"_54":31,"_176":31,"_177":31},"decisions","Decisions",{},"changelog","Changelog",{},"roadmap","Roadmap",{},"Documents",{},"activity","Activity","insights",{},"Releases",{},"Deployments","automations/deployments",{},"Workflows",{},"discussions","Discussions",{},"goals","Goals",{},{},{},{},"groups","user","agents",[],"now",1794651422693,"sidebar","expanded"]