[{"_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",{"_41":42,"_227":-5,"_228":-5,"_229":230},"routes/repo",{"_34":-7,"_35":36,"_37":38,"_39":40,"_41":42,"_43":32,"_44":32,"_45":32,"_46":32,"_47":32,"_48":32,"_49":50,"_51":50,"_52":32,"_53":-7,"_54":-7,"_55":56,"_57":58,"_59":60,"_61":-5,"_62":63,"_64":65,"_66":67,"_68":69},"routes/repo.blob",{"_13":14,"_15":16,"_17":18,"_19":20,"_21":22,"_23":24,"_25":-5,"_26":27,"_28":29,"_29":30,"_31":32,"_33":14},"ref","main","path","apps/server/src/storage/memory/research.ts","oid","a5ca3c133a47ddcf4345b4d02ed829a84f19067c","size",37454,"commit","2182c95de44a8f63fd86af1c5874ae0ca298f807","mounts",[],"source","plain",{"_13":14,"_15":16},"kind","text","import { conflict, missing } from \"../errors\";\nimport { deterministicChannelId } from \"../../channels/id\";\nimport {\n\tRESEARCH_REPOSITORY_CHANNEL_LIMIT,\n\tRESEARCH_REPOSITORY_CHANNEL_WORKSPACE_LIMIT,\n\tRESEARCH_REPOSITORY_WORKSPACE_LIMIT,\n\tresearchAttemptDisposition,\n} from \"../model\";\n\nimport type {\n\tAppendResearchAgentMessage,\n\tAppendResearchAgentMessageResult,\n\tAppendResearchTurn,\n\tAppendResearchTurnResult,\n\tBackgroundJobDetail,\n\tBackgroundJobState,\n\tChannelRecord,\n\tConfirmResearchWorkspace,\n\tConfirmResearchWorkspaceResult,\n\tCreateChannel,\n\tCreateResearchWorkspace,\n\tCreateResearchWorkspaceResult,\n\tLease,\n\tLinkResearchTurnJob,\n\tLinkResearchTurnJobResult,\n\tPublishInitialResearchReport,\n\tPublishInitialResearchReportResult,\n\tResearchJobRole,\n\tResearchMessage,\n\tResearchTerminalRecovery,\n\tResearchTurn,\n\tResearchWorkspace,\n\tResearchWorkspaceDetail,\n\tResearchWorkspaceRepositoryGroup,\n\tResearchWorkspaceRepositoryList,\n\tResearchWorkspaceSummary,\n\tResetInitialResearchAttempt,\n\tResetInitialResearchAttemptResult,\n\tStartResearchWorkspace,\n\tStartResearchWorkspaceResult,\n} from \"../model\";\nimport type { ResearchWorkspaceStore } from \"../port\";\n\ntype Options = {\n\tchannelExists: (channelId: string) => boolean;\n\tchannelActive: (channelId: string) => boolean;\n\tchannel: (channelId: string) => ChannelRecord | undefined;\n\tchannels: (repositoryId: string) => ChannelRecord[];\n\tuserExists: (userId: string) => boolean;\n\tjob: (channelId: string, jobId: string) => Promise;\n\tpublication: (\n\t\texecute: (access: {\n\t\t\tchannel: (channelId: string) => ChannelRecord | undefined;\n\t\t\tjob: (channelId: string, jobId: string) => BackgroundJobDetail | undefined;\n\t\t\tcreateAvailableChannel: (input: CreateChannel) => ChannelRecord;\n\t\t}) => T,\n\t) => T;\n\tassertLease: (lease: Lease) => void;\n};\n\ntype LinkedJob = { turnId: string; role: ResearchJobRole };\n\nfunction required(value: string, field: string): void {\n\tif (!value) throw conflict(`research ${field} must not be empty`);\n}\n\nfunction optional(value: string | undefined, field: string): void {\n\tif (value !== undefined) required(value, field);\n}\n\nfunction timestamp(value: Date, field: string): Date {\n\tif (!(value instanceof Date) || Number.isNaN(value.getTime())) {\n\t\tthrow conflict(`research ${field} must be a valid timestamp`);\n\t}\n\treturn new Date(value);\n}\n\nfunction workspace(value: ResearchWorkspace): ResearchWorkspace {\n\treturn {\n\t\t...value,\n\t\tcreatedAt: new Date(value.createdAt),\n\t\tupdatedAt: new Date(value.updatedAt),\n\t};\n}\n\nfunction turn(value: ResearchTurn): ResearchTurn {\n\treturn {\n\t\t...value,\n\t\tcreatedAt: new Date(value.createdAt),\n\t\tupdatedAt: new Date(value.updatedAt),\n\t};\n}\n\nfunction message(value: ResearchMessage): ResearchMessage {\n\treturn { ...value, createdAt: new Date(value.createdAt) };\n}\n\nfunction key(parent: string, value: string): string {\n\treturn `${parent}\\u0000${value}`;\n}\n\nfunction compareId(left: string, right: string): number {\n\treturn left < right ? -1 : left > right ? 1 : 0;\n}\n\nfunction same(left: string | undefined, right: string | undefined): boolean {\n\treturn left === right;\n}\n\n/** Serialized, deeply-cloned research persistence for provider contract and domain tests. */\nexport class MemoryResearchWorkspaceStore implements ResearchWorkspaceStore {\n\t#options: Options;\n\t#workspaces = new Map();\n\t#idempotency = new Map();\n\t#turns = new Map();\n\t#turnIds = new Map();\n\t#turnRequests = new Map();\n\t#messages = new Map();\n\t#messageIds = new Map();\n\t#agentMessagesByJob = new Map();\n\t#nextOrdinals = new Map();\n\t#nextSequences = new Map();\n\t#linkedJobs = new Map();\n\t#writeTail = Promise.resolve();\n\n\tconstructor(options: Options) {\n\t\tthis.#options = options;\n\t}\n\n\treadonly create = (input: CreateResearchWorkspace): Promise =>\n\t\tthis.#mutate(async () => {\n\t\t\tthis.#assertChannel(input.channelId, input.lease);\n\t\t\trequired(input.idempotencyKey, \"workspace idempotency key\");\n\t\t\trequired(input.fingerprint, \"workspace fingerprint\");\n\t\t\tlet repeatedId = this.#idempotency.get(key(input.channelId, input.idempotencyKey));\n\t\t\tif (repeatedId) {\n\t\t\t\tlet repeated = this.#workspaces.get(repeatedId)!;\n\t\t\t\tif (repeated.fingerprint !== input.fingerprint) {\n\t\t\t\t\tthrow conflict(`research workspace idempotency key ${input.idempotencyKey} was reused`);\n\t\t\t\t}\n\t\t\t\treturn { workspace: workspace(repeated), repeated: true };\n\t\t\t}\n\t\t\tthis.#assertActiveChannel(input.channelId, input.lease);\n\n\t\t\tthis.#requireUser(input.createdBy);\n\t\t\trequired(input.id, \"workspace id\");\n\t\t\trequired(input.title, \"workspace title\");\n\t\t\trequired(input.proposedQuestion, \"workspace proposed question\");\n\t\t\toptional(input.originMessageId, \"workspace origin message id\");\n\t\t\tif (input.origin !== \"sidebar\" && input.origin !== \"planner\") {\n\t\t\t\tthrow conflict(\"research workspace origin is invalid\");\n\t\t\t}\n\t\t\tif (this.#workspaces.has(input.id)) {\n\t\t\t\tthrow conflict(`research workspace ${input.id} already exists`);\n\t\t\t}\n\t\t\tlet now = timestamp(input.now, \"workspace creation time\");\n\t\t\tlet saved: ResearchWorkspace = {\n\t\t\t\tid: input.id,\n\t\t\t\tchannelId: input.channelId,\n\t\t\t\tpublishedChannelId: undefined,\n\t\t\t\ttitle: input.title,\n\t\t\t\tproposedQuestion: input.proposedQuestion,\n\t\t\t\tconfirmedQuery: undefined,\n\t\t\t\torigin: input.origin,\n\t\t\t\toriginMessageId: input.originMessageId,\n\t\t\t\tcreatedBy: input.createdBy,\n\t\t\t\tconfirmedBy: undefined,\n\t\t\t\trevision: 0,\n\t\t\t\tidempotencyKey: input.idempotencyKey,\n\t\t\t\tfingerprint: input.fingerprint,\n\t\t\t\tcreatedAt: now,\n\t\t\t\tupdatedAt: now,\n\t\t\t};\n\t\t\tthis.#workspaces.set(saved.id, saved);\n\t\t\tthis.#idempotency.set(key(saved.channelId, saved.idempotencyKey), saved.id);\n\t\t\tthis.#turns.set(saved.id, []);\n\t\t\tthis.#messages.set(saved.id, []);\n\t\t\tthis.#nextOrdinals.set(saved.id, 1);\n\t\t\tthis.#nextSequences.set(saved.id, 1);\n\t\t\treturn { workspace: workspace(saved), repeated: false };\n\t\t});\n\n\treadonly start = (\n\t\tinput: StartResearchWorkspace,\n\t): Promise =>\n\t\tthis.#mutate(async () => {\n\t\t\tthis.#assertChannel(input.channelId, input.lease);\n\t\t\trequired(input.idempotencyKey, \"workspace idempotency key\");\n\t\t\trequired(input.fingerprint, \"workspace fingerprint\");\n\t\t\tif (input.origin !== \"inline\" && input.origin !== \"planner\") {\n\t\t\t\tthrow conflict(\"research workspace start origin is invalid\");\n\t\t\t}\n\t\t\tif (input.inlineReference && input.origin !== \"planner\") {\n\t\t\t\tthrow conflict(\"inline reference requires Planner origin\");\n\t\t\t}\n\t\t\tif (\n\t\t\t\tinput.origin === \"inline\" && input.originMessageId !== undefined\n\t\t\t\t|| input.origin === \"planner\" && !input.originMessageId\n\t\t\t) throw conflict(\"research workspace start origin message is invalid\");\n\t\t\tlet repeatedId = this.#idempotency.get(key(input.channelId, input.idempotencyKey));\n\t\t\tif (repeatedId) {\n\t\t\t\tlet repeated = this.#workspaces.get(repeatedId)!;\n\t\t\t\tlet repeatedTurn = (this.#turns.get(repeated.id) ?? [])[0];\n\t\t\t\tif (\n\t\t\t\t\trepeated.fingerprint !== input.fingerprint\n\t\t\t\t\t|| repeated.origin !== input.origin\n\t\t\t\t\t|| repeated.originMessageId !== input.originMessageId\n\t\t\t\t\t|| !repeatedTurn\n\t\t\t\t\t|| repeatedTurn.kind !== \"initial\"\n\t\t\t\t) {\n\t\t\t\t\tthrow conflict(\n\t\t\t\t\t\t`research workspace idempotency key ${input.idempotencyKey} was reused`,\n\t\t\t\t\t);\n\t\t\t\t}\n\t\t\t\tif (input.inlineReference && !repeated.inlineReference) {\n\t\t\t\t\trepeated.inlineReference = \"pending\";\n\t\t\t\t}\n\t\t\t\treturn {\n\t\t\t\t\tworkspace: workspace(repeated),\n\t\t\t\t\tturn: turn(repeatedTurn),\n\t\t\t\t\tmessage: message(this.#memberMessage(repeatedTurn)),\n\t\t\t\t\trepeated: true,\n\t\t\t\t};\n\t\t\t}\n\t\t\tthis.#assertActiveChannel(input.channelId, input.lease);\n\t\t\tthis.#requireUser(input.createdBy);\n\t\t\trequired(input.id, \"workspace id\");\n\t\t\trequired(input.title, \"workspace title\");\n\t\t\trequired(input.question, \"workspace question\");\n\t\t\trequired(input.turnId, \"turn id\");\n\t\t\trequired(input.messageId, \"message id\");\n\t\t\trequired(input.requestId, \"request id\");\n\t\t\toptional(input.createdByHandle, \"creating member handle\");\n\t\t\tif (this.#workspaces.has(input.id)) {\n\t\t\t\tthrow conflict(`research workspace ${input.id} already exists`);\n\t\t\t}\n\t\t\tthis.#assertNewTurn(input.turnId, input.messageId);\n\t\t\tlet now = timestamp(input.now, \"workspace start time\");\n\t\t\tlet savedWorkspace: ResearchWorkspace = {\n\t\t\t\tid: input.id,\n\t\t\t\tchannelId: input.channelId,\n\t\t\t\tpublishedChannelId: undefined,\n\t\t\t\ttitle: input.title,\n\t\t\t\tproposedQuestion: input.question,\n\t\t\t\tconfirmedQuery: input.question,\n\t\t\t\torigin: input.origin,\n\t\t\t\toriginMessageId: input.originMessageId,\n\t\t\t\t...(input.inlineReference ? { inlineReference: input.inlineReference } : {}),\n\t\t\t\tcreatedBy: input.createdBy,\n\t\t\t\tconfirmedBy: input.createdBy,\n\t\t\t\trevision: 0,\n\t\t\t\tidempotencyKey: input.idempotencyKey,\n\t\t\t\tfingerprint: input.fingerprint,\n\t\t\t\tcreatedAt: now,\n\t\t\t\tupdatedAt: now,\n\t\t\t};\n\t\t\tthis.#workspaces.set(savedWorkspace.id, savedWorkspace);\n\t\t\tthis.#idempotency.set(\n\t\t\t\tkey(savedWorkspace.channelId, savedWorkspace.idempotencyKey),\n\t\t\t\tsavedWorkspace.id,\n\t\t\t);\n\t\t\tthis.#turns.set(savedWorkspace.id, []);\n\t\t\tthis.#messages.set(savedWorkspace.id, []);\n\t\t\tthis.#nextOrdinals.set(savedWorkspace.id, 1);\n\t\t\tthis.#nextSequences.set(savedWorkspace.id, 1);\n\t\t\tlet savedTurn = this.#newTurn({\n\t\t\t\tworkspaceId: savedWorkspace.id,\n\t\t\t\tid: input.turnId,\n\t\t\t\tkind: \"initial\",\n\t\t\t\trequestId: input.requestId,\n\t\t\t\tfingerprint: input.fingerprint,\n\t\t\t\tquestion: input.question,\n\t\t\t\trequestedBy: input.createdBy,\n\t\t\t\tnow,\n\t\t\t});\n\t\t\tlet savedMessage = this.#newMemberMessage(\n\t\t\t\tsavedWorkspace.id,\n\t\t\t\tinput.messageId,\n\t\t\t\tsavedTurn,\n\t\t\t\tinput.createdByHandle,\n\t\t\t\tnow,\n\t\t\t);\n\t\t\treturn {\n\t\t\t\tworkspace: workspace(savedWorkspace),\n\t\t\t\tturn: turn(savedTurn),\n\t\t\t\tmessage: message(savedMessage),\n\t\t\t\trepeated: false,\n\t\t\t};\n\t\t});\n\n\treadonly markReferencePlaced = (input: {\n\t\tchannelId: string;\n\t\tworkspaceId: string;\n\t\tlease: Lease;\n\t}): Promise =>\n\t\tthis.#mutate(async () => {\n\t\t\tthis.#assertChannel(input.channelId, input.lease);\n\t\t\tlet found = this.#requireWorkspace(input.channelId, input.workspaceId);\n\t\t\tif (!found.inlineReference) throw conflict(\"research reference placement is not required\");\n\t\t\tfound.inlineReference = \"placed\";\n\t\t});\n\n\treadonly listReferenceRecovery = async (\n\t\tlimit: number,\n\t\tafterId?: string,\n\t\tchannelId?: string,\n\t): Promise => {\n\t\tlet count = Math.min(100, Math.max(1, limit));\n\t\treturn [...this.#workspaces.values()]\n\t\t\t.filter(value => !channelId || value.channelId === channelId)\n\t\t\t.filter(value =>\n\t\t\t\tvalue.inlineReference === \"pending\"\n\t\t\t\t|| value.inlineReference === \"placed\"\n\t\t\t\t\t&& !(this.#turns.get(value.id) ?? [])[0]?.evidenceJobId\n\t\t\t)\n\t\t\t.filter(value => !afterId || compareId(value.id, afterId) > 0)\n\t\t\t.sort((left, right) => compareId(left.id, right.id))\n\t\t\t.slice(0, count)\n\t\t\t.map(workspace);\n\t};\n\n\treadonly listTerminalRecovery = async (\n\t\tlimit: number,\n\t\tafterId?: string,\n\t\tchannelId?: string,\n\t): Promise => {\n\t\tlet count = Math.min(100, Math.max(1, limit));\n\t\tlet candidates = [...this.#workspaces.values()]\n\t\t\t.filter(value => value.origin === \"planner\" && value.inlineReference === \"placed\")\n\t\t\t.filter(value => !channelId || value.channelId === channelId)\n\t\t\t.filter(value => !afterId || compareId(value.id, afterId) > 0)\n\t\t\t.sort((left, right) => compareId(left.id, right.id));\n\t\tlet page: ResearchTerminalRecovery[] = [];\n\t\tfor (let value of candidates) {\n\t\t\tlet initial = (this.#turns.get(value.id) ?? []).find(turn => turn.kind === \"initial\");\n\t\t\tif (!initial) continue;\n\t\t\tlet answer = initial.answerJobId\n\t\t\t\t? await this.#options.job(value.channelId, initial.answerJobId)\n\t\t\t\t: undefined;\n\t\t\tlet evidence = initial.evidenceJobId\n\t\t\t\t? await this.#options.job(value.channelId, initial.evidenceJobId)\n\t\t\t\t: undefined;\n\t\t\tlet jobId: string | undefined;\n\t\t\tif (\n\t\t\t\tanswer?.job.state === \"failed\"\n\t\t\t\t|| answer?.job.state === \"completed\" && value.publishedChannelId\n\t\t\t) jobId = answer.job.id;\n\t\t\telse if (evidence?.job.state === \"failed\") jobId = evidence.job.id;\n\t\t\tif (jobId) page.push({ id: value.id, channelId: value.channelId, jobId });\n\t\t\tif (page.length === count) break;\n\t\t}\n\t\treturn page;\n\t};\n\n\treadonly confirm = (\n\t\tinput: ConfirmResearchWorkspace,\n\t): Promise =>\n\t\tthis.#mutate(async () => {\n\t\t\tthis.#assertChannel(input.channelId, input.lease);\n\t\t\tlet found = this.#requireWorkspace(input.channelId, input.workspaceId);\n\t\t\trequired(input.requestId, \"confirmation request id\");\n\t\t\trequired(input.fingerprint, \"confirmation fingerprint\");\n\t\t\trequired(input.confirmedQuery, \"confirmed query\");\n\t\t\trequired(input.confirmedBy, \"confirming member id\");\n\t\t\toptional(input.confirmedByHandle, \"confirming member handle\");\n\t\t\tthis.#requireUser(input.confirmedBy);\n\n\t\t\tlet repeated = this.#turnForRequest(found.id, input.requestId);\n\t\t\tif (repeated) {\n\t\t\t\tlet repeatedMessage = this.#memberMessage(repeated);\n\t\t\t\tif (\n\t\t\t\t\trepeated.kind !== \"initial\"\n\t\t\t\t\t|| repeated.fingerprint !== input.fingerprint\n\t\t\t\t\t|| repeated.question !== input.confirmedQuery\n\t\t\t\t\t|| repeated.requestedBy !== input.confirmedBy\n\t\t\t\t\t|| !same(repeatedMessage.userHandle, input.confirmedByHandle)\n\t\t\t\t) throw conflict(`research request ${input.requestId} was reused with another payload`);\n\t\t\t\treturn {\n\t\t\t\t\tworkspace: workspace(found),\n\t\t\t\t\tturn: turn(repeated),\n\t\t\t\t\tmessage: message(repeatedMessage),\n\t\t\t\t\trepeated: true,\n\t\t\t\t};\n\t\t\t}\n\t\t\tthis.#assertActiveChannel(input.channelId, input.lease);\n\t\t\tif (found.confirmedQuery !== undefined) {\n\t\t\t\tthrow conflict(`research workspace ${found.id} is already confirmed`);\n\t\t\t}\n\t\t\trequired(input.turnId, \"turn id\");\n\t\t\trequired(input.messageId, \"message id\");\n\t\t\tthis.#assertNewTurn(input.turnId, input.messageId);\n\t\t\tlet now = timestamp(input.now, \"confirmation time\");\n\t\t\tlet savedTurn = this.#newTurn({\n\t\t\t\tworkspaceId: found.id,\n\t\t\t\tid: input.turnId,\n\t\t\t\tkind: \"initial\",\n\t\t\t\trequestId: input.requestId,\n\t\t\t\tfingerprint: input.fingerprint,\n\t\t\t\tquestion: input.confirmedQuery,\n\t\t\t\trequestedBy: input.confirmedBy,\n\t\t\t\tnow,\n\t\t\t});\n\t\t\tlet savedMessage = this.#newMemberMessage(\n\t\t\t\tfound.id,\n\t\t\t\tinput.messageId,\n\t\t\t\tsavedTurn,\n\t\t\t\tinput.confirmedByHandle,\n\t\t\t\tnow,\n\t\t\t);\n\t\t\tlet savedWorkspace = this.#saveWorkspace({\n\t\t\t\t...found,\n\t\t\t\tconfirmedQuery: input.confirmedQuery,\n\t\t\t\tconfirmedBy: input.confirmedBy,\n\t\t\t}, now);\n\t\t\treturn {\n\t\t\t\tworkspace: workspace(savedWorkspace),\n\t\t\t\tturn: turn(savedTurn),\n\t\t\t\tmessage: message(savedMessage),\n\t\t\t\trepeated: false,\n\t\t\t};\n\t\t});\n\n\treadonly appendTurn = (input: AppendResearchTurn): Promise =>\n\t\tthis.#mutate(async () => {\n\t\t\tthis.#assertChannel(input.channelId, input.lease);\n\t\t\tlet found = this.#requireWorkspace(input.channelId, input.workspaceId);\n\t\t\trequired(input.requestId, \"turn request id\");\n\t\t\trequired(input.fingerprint, \"turn fingerprint\");\n\t\t\trequired(input.question, \"turn question\");\n\t\t\trequired(input.requestedBy, \"requesting member id\");\n\t\t\toptional(input.requestedByHandle, \"requesting member handle\");\n\t\t\tif (input.kind !== \"follow-up\" && input.kind !== \"search-more\") {\n\t\t\t\tthrow conflict(\"research appended turn kind is invalid\");\n\t\t\t}\n\t\t\tthis.#requireUser(input.requestedBy);\n\n\t\t\tlet repeated = this.#turnForRequest(found.id, input.requestId);\n\t\t\tif (repeated) {\n\t\t\t\tlet repeatedMessage = this.#memberMessage(repeated);\n\t\t\t\tif (\n\t\t\t\t\trepeated.kind !== input.kind\n\t\t\t\t\t|| repeated.fingerprint !== input.fingerprint\n\t\t\t\t\t|| repeated.question !== input.question\n\t\t\t\t\t|| repeated.requestedBy !== input.requestedBy\n\t\t\t\t\t|| !same(repeatedMessage.userHandle, input.requestedByHandle)\n\t\t\t\t) throw conflict(`research request ${input.requestId} was reused with another payload`);\n\t\t\t\treturn {\n\t\t\t\t\tworkspace: workspace(found),\n\t\t\t\t\tturn: turn(repeated),\n\t\t\t\t\tmessage: message(repeatedMessage),\n\t\t\t\t\trepeated: true,\n\t\t\t\t};\n\t\t\t}\n\t\t\tthis.#assertActiveChannel(input.channelId, input.lease);\n\t\t\tif (found.confirmedQuery === undefined) {\n\t\t\t\tthrow conflict(`research workspace ${found.id} is not confirmed`);\n\t\t\t}\n\t\t\trequired(input.turnId, \"turn id\");\n\t\t\trequired(input.messageId, \"message id\");\n\t\t\tthis.#assertNewTurn(input.turnId, input.messageId);\n\t\t\tlet now = timestamp(input.now, \"turn creation time\");\n\t\t\tlet savedTurn = this.#newTurn({\n\t\t\t\tworkspaceId: found.id,\n\t\t\t\tid: input.turnId,\n\t\t\t\tkind: input.kind,\n\t\t\t\trequestId: input.requestId,\n\t\t\t\tfingerprint: input.fingerprint,\n\t\t\t\tquestion: input.question,\n\t\t\t\trequestedBy: input.requestedBy,\n\t\t\t\tnow,\n\t\t\t});\n\t\t\tlet savedMessage = this.#newMemberMessage(\n\t\t\t\tfound.id,\n\t\t\t\tinput.messageId,\n\t\t\t\tsavedTurn,\n\t\t\t\tinput.requestedByHandle,\n\t\t\t\tnow,\n\t\t\t);\n\t\t\tlet savedWorkspace = this.#saveWorkspace(found, now);\n\t\t\treturn {\n\t\t\t\tworkspace: workspace(savedWorkspace),\n\t\t\t\tturn: turn(savedTurn),\n\t\t\t\tmessage: message(savedMessage),\n\t\t\t\trepeated: false,\n\t\t\t};\n\t\t});\n\n\treadonly linkJob = (input: LinkResearchTurnJob): Promise =>\n\t\tthis.#mutate(async () => {\n\t\t\tthis.#assertChannel(input.channelId, input.lease);\n\t\t\tlet found = this.#requireWorkspace(input.channelId, input.workspaceId);\n\t\t\trequired(input.turnId, \"turn id\");\n\t\t\trequired(input.jobId, \"linked job id\");\n\t\t\tif (input.role !== \"evidence\" && input.role !== \"answer\") {\n\t\t\t\tthrow conflict(\"research job role is invalid\");\n\t\t\t}\n\t\t\tlet foundTurn = this.#requireTurn(found.id, input.turnId);\n\t\t\tlet job = await this.#options.job(input.channelId, input.jobId);\n\t\t\tif (!job) {\n\t\t\t\tthrow missing(`background job ${input.jobId} does not exist in channel ${input.channelId}`);\n\t\t\t}\n\t\t\tlet type = input.role === \"evidence\" ? \"research-evidence\" : \"research-answer\";\n\t\t\tlet target = `${type}:workspace:${found.id}:turn:${foundTurn.id}:${input.role}`;\n\t\t\tif (\n\t\t\t\tjob.job.type !== type || job.job.targetKey !== target\n\t\t\t\t|| job.job.targetGeneration !== job.target.generation\n\t\t\t) {\n\t\t\t\tthrow conflict(\n\t\t\t\t\t`background job ${input.jobId} is not current ${input.role} work for the turn`,\n\t\t\t\t);\n\t\t\t}\n\t\t\tthis.#options.assertLease(input.lease);\n\t\t\tlet current = input.role === \"evidence\"\n\t\t\t\t? foundTurn.evidenceJobId\n\t\t\t\t: foundTurn.answerJobId;\n\t\t\tif (current !== undefined) {\n\t\t\t\tif (current !== input.jobId) {\n\t\t\t\t\tthrow conflict(`research turn ${foundTurn.id} already has an ${input.role} job`);\n\t\t\t\t}\n\t\t\t\treturn { workspace: workspace(found), turn: turn(foundTurn), repeated: true };\n\t\t\t}\n\t\t\tlet linked = this.#linkedJobs.get(input.jobId);\n\t\t\tif (linked) {\n\t\t\t\tthrow conflict(`background job ${input.jobId} is already linked to a research turn`);\n\t\t\t}\n\t\t\tlet now = timestamp(input.now, \"job link time\");\n\t\t\tlet savedTurn: ResearchTurn = {\n\t\t\t\t...foundTurn,\n\t\t\t\t...(input.role === \"evidence\"\n\t\t\t\t\t? { evidenceJobId: input.jobId }\n\t\t\t\t\t: { answerJobId: input.jobId }),\n\t\t\t\tupdatedAt: new Date(Math.max(foundTurn.updatedAt.getTime(), now.getTime())),\n\t\t\t};\n\t\t\tthis.#replaceTurn(savedTurn);\n\t\t\tthis.#linkedJobs.set(input.jobId, { turnId: savedTurn.id, role: input.role });\n\t\t\tlet savedWorkspace = this.#saveWorkspace(found, now);\n\t\t\treturn {\n\t\t\t\tworkspace: workspace(savedWorkspace),\n\t\t\t\tturn: turn(savedTurn),\n\t\t\t\trepeated: false,\n\t\t\t};\n\t\t});\n\n\treadonly resetInitialAttempt = (\n\t\tinput: ResetInitialResearchAttempt,\n\t): Promise =>\n\t\tthis.#mutate(async () => {\n\t\t\tthis.#assertActiveChannel(input.channelId, input.lease);\n\t\t\tlet found = this.#requireWorkspace(input.channelId, input.workspaceId);\n\t\t\tif (found.publishedChannelId) {\n\t\t\t\tthrow conflict(`research workspace ${found.id} is already published`);\n\t\t\t}\n\t\t\tlet foundTurn = (this.#turns.get(found.id) ?? [])[0];\n\t\t\tif (!foundTurn || foundTurn.kind !== \"initial\") {\n\t\t\t\tthrow conflict(`research workspace ${found.id} has no initial turn`);\n\t\t\t}\n\t\t\tif (\n\t\t\t\tfoundTurn.evidenceJobId !== input.expectedEvidenceJobId\n\t\t\t\t|| foundTurn.answerJobId !== input.expectedAnswerJobId\n\t\t\t) throw conflict(`research workspace ${found.id} changed before retry`);\n\t\t\tif (!foundTurn.evidenceJobId && !foundTurn.answerJobId) {\n\t\t\t\treturn { workspace: workspace(found), turn: turn(foundTurn), repeated: true };\n\t\t\t}\n\t\t\tlet states: BackgroundJobState[] = [];\n\t\t\tfor (let jobId of [foundTurn.evidenceJobId, foundTurn.answerJobId]) {\n\t\t\t\tif (!jobId) continue;\n\t\t\t\tlet detail = await this.#options.job(input.channelId, jobId);\n\t\t\t\tif (!detail) {\n\t\t\t\t\tthrow missing(`background job ${jobId} does not exist in channel ${input.channelId}`);\n\t\t\t\t}\n\t\t\t\tstates.push(detail.job.state);\n\t\t\t}\n\t\t\tlet disposition = researchAttemptDisposition(states);\n\t\t\tif (disposition === \"active\") {\n\t\t\t\tthrow conflict(`research workspace ${found.id} still has active initial work`);\n\t\t\t}\n\t\t\tif (disposition !== \"retryable\") {\n\t\t\t\tthrow conflict(`research workspace ${found.id} has no terminal initial work`);\n\t\t\t}\n\t\t\tthis.#assertActiveChannel(input.channelId, input.lease);\n\t\t\tlet now = timestamp(input.now, \"retry time\");\n\t\t\tlet savedTurn: ResearchTurn = {\n\t\t\t\t...foundTurn,\n\t\t\t\tevidenceJobId: undefined,\n\t\t\t\tanswerJobId: undefined,\n\t\t\t\tupdatedAt: new Date(Math.max(foundTurn.updatedAt.getTime(), now.getTime())),\n\t\t\t};\n\t\t\tthis.#replaceTurn(savedTurn);\n\t\t\tif (foundTurn.evidenceJobId) this.#linkedJobs.delete(foundTurn.evidenceJobId);\n\t\t\tif (foundTurn.answerJobId) this.#linkedJobs.delete(foundTurn.answerJobId);\n\t\t\tlet savedWorkspace = this.#saveWorkspace(found, now);\n\t\t\treturn {\n\t\t\t\tworkspace: workspace(savedWorkspace),\n\t\t\t\tturn: turn(savedTurn),\n\t\t\t\trepeated: false,\n\t\t\t};\n\t\t});\n\n\treadonly appendAgentMessage = (\n\t\tinput: AppendResearchAgentMessage,\n\t): Promise =>\n\t\tthis.#mutate(async () => {\n\t\t\tthis.#assertChannel(input.channelId, input.lease);\n\t\t\tlet found = this.#requireWorkspace(input.channelId, input.workspaceId);\n\t\t\trequired(input.id, \"message id\");\n\t\t\trequired(input.turnId, \"message turn id\");\n\t\t\trequired(input.sourceJobId, \"message source job id\");\n\t\t\trequired(input.text, \"message text\");\n\t\t\toptional(input.userId, \"message user id\");\n\t\t\toptional(input.userHandle, \"message user handle\");\n\t\t\tif (input.userId) this.#requireUser(input.userId);\n\t\t\tlet repeated = this.#messageIds.get(input.id)\n\t\t\t\t?? this.#agentMessagesByJob.get(input.sourceJobId);\n\t\t\tif (repeated) {\n\t\t\t\tif (\n\t\t\t\t\trepeated.workspaceId !== found.id\n\t\t\t\t\t|| repeated.authorKind !== \"agent\"\n\t\t\t\t\t|| repeated.turnId !== input.turnId\n\t\t\t\t\t|| repeated.sourceJobId !== input.sourceJobId\n\t\t\t\t\t|| repeated.userId !== input.userId\n\t\t\t\t\t|| repeated.userHandle !== input.userHandle\n\t\t\t\t\t|| repeated.text !== input.text\n\t\t\t\t) throw conflict(`research message ${input.id} was reused with another payload`);\n\t\t\t\treturn { workspace: workspace(found), message: message(repeated), repeated: true };\n\t\t\t}\n\t\t\tlet foundTurn = this.#requireTurn(found.id, input.turnId);\n\t\t\tif (foundTurn.answerJobId !== input.sourceJobId) {\n\t\t\t\tthrow conflict(\n\t\t\t\t\t`research turn ${foundTurn.id} is not linked to answer job ${input.sourceJobId}`,\n\t\t\t\t);\n\t\t\t}\n\t\t\tif (!await this.#options.job(input.channelId, input.sourceJobId)) {\n\t\t\t\tthrow missing(\n\t\t\t\t\t`background job ${input.sourceJobId} does not exist in channel ${input.channelId}`,\n\t\t\t\t);\n\t\t\t}\n\t\t\tthis.#options.assertLease(input.lease);\n\t\t\tlet now = timestamp(input.now, \"message creation time\");\n\t\t\tlet sequence = this.#nextSequences.get(found.id) ?? 1;\n\t\t\tlet savedMessage: ResearchMessage = {\n\t\t\t\tid: input.id,\n\t\t\t\tworkspaceId: found.id,\n\t\t\t\tsequence,\n\t\t\t\tturnId: input.turnId,\n\t\t\t\tauthorKind: \"agent\",\n\t\t\t\tuserId: input.userId,\n\t\t\t\tuserHandle: input.userHandle,\n\t\t\t\ttext: input.text,\n\t\t\t\tsourceJobId: input.sourceJobId,\n\t\t\t\tcreatedAt: now,\n\t\t\t};\n\t\t\tthis.#messages.get(found.id)!.push(savedMessage);\n\t\t\tthis.#messageIds.set(savedMessage.id, savedMessage);\n\t\t\tthis.#agentMessagesByJob.set(savedMessage.sourceJobId!, savedMessage);\n\t\t\tthis.#nextSequences.set(found.id, sequence + 1);\n\t\t\tlet savedWorkspace = this.#saveWorkspace(found, now);\n\t\t\treturn {\n\t\t\t\tworkspace: workspace(savedWorkspace),\n\t\t\t\tmessage: message(savedMessage),\n\t\t\t\trepeated: false,\n\t\t\t};\n\t\t});\n\n\treadonly publishInitialReport = (\n\t\tinput: PublishInitialResearchReport,\n\t): Promise =>\n\t\tthis.#mutate(async () => {\n\t\t\tthis.#assertChannel(input.channelId, input.lease);\n\t\t\tlet found = this.#requireWorkspace(input.channelId, input.workspaceId);\n\t\t\trequired(input.answerJobId, \"publication answer job id\");\n\t\t\trequired(input.title, \"publication title\");\n\t\t\tlet initialTurn = (this.#turns.get(found.id) ?? [])[0];\n\t\t\tif (\n\t\t\t\t!initialTurn\n\t\t\t\t|| initialTurn.kind !== \"initial\"\n\t\t\t\t|| initialTurn.answerJobId !== input.answerJobId\n\t\t\t) {\n\t\t\t\tthrow conflict(\n\t\t\t\t\t`research workspace ${found.id} is not linked to initial answer job ${input.answerJobId}`,\n\t\t\t\t);\n\t\t\t}\n\t\t\tif (found.publishedChannelId) {\n\t\t\t\tlet published = this.#options.channel(found.publishedChannelId);\n\t\t\t\tif (!published) {\n\t\t\t\t\tthrow missing(`published channel ${found.publishedChannelId} does not exist`);\n\t\t\t\t}\n\t\t\t\treturn { workspace: workspace(found), channel: published, repeated: true };\n\t\t\t}\n\t\t\tthis.#assertActiveChannel(input.channelId, input.lease);\n\t\t\tlet parent = this.#options.channel(input.channelId);\n\t\t\tif (!parent) throw missing(`channel ${input.channelId} does not exist`);\n\t\t\tif (parent.parentChannelId) {\n\t\t\t\tthrow conflict(`channel ${parent.id} cannot parent another child`);\n\t\t\t}\n\t\t\tlet answer = await this.#options.job(input.channelId, input.answerJobId);\n\t\t\tlet target = `research-answer:workspace:${found.id}:turn:${initialTurn.id}:answer`;\n\t\t\tif (\n\t\t\t\t!answer\n\t\t\t\t|| answer.job.channelId !== input.channelId\n\t\t\t\t|| answer.job.type !== \"research-answer\"\n\t\t\t\t|| answer.job.targetKey !== target\n\t\t\t\t|| answer.job.targetGeneration !== answer.target.generation\n\t\t\t\t|| answer.job.state !== \"completed\"\n\t\t\t\t|| !answer.artifact\n\t\t\t) {\n\t\t\t\tthrow conflict(`background job ${input.answerJobId} is not current completed answer work`);\n\t\t\t}\n\t\t\treturn this.#options.publication(access => {\n\t\t\t\tthis.#options.assertLease(input.lease);\n\t\t\t\tlet currentParent = access.channel(input.channelId);\n\t\t\t\tif (!currentParent) throw missing(`channel ${input.channelId} does not exist`);\n\t\t\t\tif (currentParent.archivedAt) throw conflict(`channel ${input.channelId} is archived`);\n\t\t\t\tif (currentParent.parentChannelId) {\n\t\t\t\t\tthrow conflict(`channel ${input.channelId} cannot parent another child`);\n\t\t\t\t}\n\t\t\t\tlet current = access.job(input.channelId, input.answerJobId);\n\t\t\t\tif (\n\t\t\t\t\t!current\n\t\t\t\t\t|| current.job.channelId !== input.channelId\n\t\t\t\t\t|| current.job.type !== \"research-answer\"\n\t\t\t\t\t|| current.job.targetKey !== target\n\t\t\t\t\t|| current.job.targetGeneration !== current.target.generation\n\t\t\t\t\t|| current.job.state !== \"completed\"\n\t\t\t\t\t|| !current.artifact\n\t\t\t\t) {\n\t\t\t\t\tthrow conflict(\n\t\t\t\t\t\t`background job ${input.answerJobId} is not current completed answer work`,\n\t\t\t\t\t);\n\t\t\t\t}\n\t\t\t\tlet now = timestamp(input.now, \"publication time\");\n\t\t\t\tlet child = access.createAvailableChannel({\n\t\t\t\t\tid: deterministicChannelId(currentParent.repositoryId, found.id),\n\t\t\t\t\trepositoryId: currentParent.repositoryId,\n\t\t\t\t\trepositoryOwner: currentParent.repositoryOwner,\n\t\t\t\t\trepositoryName: currentParent.repositoryName,\n\t\t\t\t\tparentChannelId: currentParent.id,\n\t\t\t\t\ttitle: input.title,\n\t\t\t\t\tcreatedBy: found.createdBy,\n\t\t\t\t\tnow,\n\t\t\t\t\tinitial: input.initial,\n\t\t\t\t});\n\t\t\t\tlet saved = this.#saveWorkspace({\n\t\t\t\t\t...found,\n\t\t\t\t\tpublishedChannelId: child.id,\n\t\t\t\t}, now);\n\t\t\t\treturn { workspace: workspace(saved), channel: child, repeated: false };\n\t\t\t});\n\t\t});\n\n\treferencesChannel(channelId: string): boolean {\n\t\treturn [...this.#workspaces.values()].some(value => value.publishedChannelId === channelId);\n\t}\n\n\treadonly list = async (\n\t\tchannelId: string,\n\t\tlimit: number,\n\t\tincludePlanner = true,\n\t): Promise => {\n\t\tlet count = Math.min(100, Math.max(1, limit));\n\t\treturn [...this.#workspaces.values()]\n\t\t\t.filter(value =>\n\t\t\t\tvalue.channelId === channelId\n\t\t\t\t&& (includePlanner || value.origin !== \"planner\")\n\t\t\t)\n\t\t\t.sort((left, right) =>\n\t\t\t\tright.updatedAt.getTime() - left.updatedAt.getTime() || compareId(left.id, right.id)\n\t\t\t)\n\t\t\t.slice(0, count)\n\t\t\t.map(workspace);\n\t};\n\n\treadonly listRepository = async (\n\t\trepositoryId: string,\n\t\tlimit: number,\n\t\tincludeArchived = false,\n\t\tincludePlanner = true,\n\t): Promise => {\n\t\tlet count = Math.min(RESEARCH_REPOSITORY_WORKSPACE_LIMIT, Math.max(1, limit));\n\t\tlet orderedChannels = this.#options.channels(repositoryId)\n\t\t\t.filter(channel => includeArchived || !channel.archivedAt)\n\t\t\t.sort((left, right) =>\n\t\t\t\tright.createdAt.getTime() - left.createdAt.getTime() || compareId(left.id, right.id)\n\t\t\t);\n\t\tlet workspacesByChannel = new Map();\n\t\tfor (let saved of this.#workspaces.values()) {\n\t\t\tif (!includePlanner && saved.origin === \"planner\") continue;\n\t\t\tlet values = workspacesByChannel.get(saved.channelId) ?? [];\n\t\t\tvalues.push(saved);\n\t\t\tworkspacesByChannel.set(saved.channelId, values);\n\t\t}\n\t\tlet truncated = orderedChannels.length > RESEARCH_REPOSITORY_CHANNEL_LIMIT;\n\t\tlet groups: ResearchWorkspaceRepositoryGroup[] = [];\n\t\tlet workspaceCount = 0;\n\t\tfor (let channel of orderedChannels.slice(0, RESEARCH_REPOSITORY_CHANNEL_LIMIT)) {\n\t\t\tif (workspaceCount >= count) {\n\t\t\t\ttruncated = true;\n\t\t\t\tbreak;\n\t\t\t}\n\t\t\tlet workspaces = (workspacesByChannel.get(channel.id) ?? [])\n\t\t\t\t.sort((left, right) =>\n\t\t\t\t\tright.updatedAt.getTime() - left.updatedAt.getTime() || compareId(left.id, right.id)\n\t\t\t\t)\n\t\t\t\t.slice(0, RESEARCH_REPOSITORY_CHANNEL_WORKSPACE_LIMIT);\n\t\t\tif (workspaces.length === RESEARCH_REPOSITORY_CHANNEL_WORKSPACE_LIMIT) truncated = true;\n\t\t\tlet selected = workspaces.slice(0, count - workspaceCount).map(workspace);\n\t\t\tif (selected.length > 0) {\n\t\t\t\tgroups.push({\n\t\t\t\t\tchannel: {\n\t\t\t\t\t\tid: channel.id,\n\t\t\t\t\t\trepositoryId: channel.repositoryId,\n\t\t\t\t\t\trepositoryOwner: channel.repositoryOwner,\n\t\t\t\t\t\trepositoryName: channel.repositoryName,\n\t\t\t\t\t\ttitle: channel.title,\n\t\t\t\t\t\tslug: channel.slug,\n\t\t\t\t\t},\n\t\t\t\t\tworkspaces: selected,\n\t\t\t\t});\n\t\t\t}\n\t\t\tworkspaceCount += selected.length;\n\t\t}\n\t\tif (workspaceCount === count) truncated = true;\n\t\treturn { channels: groups, truncated };\n\t};\n\n\tgetCurrent(\n\t\tchannelId: string,\n\t\tworkspaceId: string,\n\t): ResearchWorkspaceDetail | undefined {\n\t\tlet found = this.#workspaces.get(workspaceId);\n\t\tif (!found || found.channelId !== channelId) return undefined;\n\t\treturn {\n\t\t\tworkspace: workspace(found),\n\t\t\tturns: (this.#turns.get(found.id) ?? []).map(turn),\n\t\t\tmessages: (this.#messages.get(found.id) ?? []).map(message),\n\t\t};\n\t}\n\n\treadonly get = async (\n\t\tchannelId: string,\n\t\tworkspaceId: string,\n\t): Promise => this.getCurrent(channelId, workspaceId);\n\n\treadonly findByIdempotencyKey = async (\n\t\tchannelId: string,\n\t\tidempotencyKey: string,\n\t): Promise => {\n\t\tlet workspaceId = this.#idempotency.get(key(channelId, idempotencyKey));\n\t\treturn workspaceId ? this.get(channelId, workspaceId) : undefined;\n\t};\n\n\treadonly findPublished = async (\n\t\tchannelId: string,\n\t\tpublishedChannelId: string,\n\t): Promise => {\n\t\tlet found = [...this.#workspaces.values()].find(value =>\n\t\t\tvalue.channelId === channelId && value.publishedChannelId === publishedChannelId\n\t\t);\n\t\treturn found ? this.get(channelId, found.id) : undefined;\n\t};\n\n\treadonly findTurnByJob = async (\n\t\tchannelId: string,\n\t\tjobId: string,\n\t): Promise => {\n\t\tlet linked = this.#linkedJobs.get(jobId);\n\t\tlet foundTurn = linked && this.#turnIds.get(linked.turnId);\n\t\tlet foundWorkspace = foundTurn && this.#workspaces.get(foundTurn.workspaceId);\n\t\treturn foundTurn && foundWorkspace?.channelId === channelId ? turn(foundTurn) : undefined;\n\t};\n\n\tdeleteChannel(channelId: string): Promise {\n\t\treturn this.#mutate(async () => {\n\t\t\tlet workspaceIds = new Set();\n\t\t\tfor (let [workspaceId, saved] of this.#workspaces) {\n\t\t\t\tif (saved.channelId === channelId) workspaceIds.add(workspaceId);\n\t\t\t}\n\t\t\tlet turnIds = new Set();\n\t\t\tlet messageIds = new Set();\n\t\t\tfor (let workspaceId of workspaceIds) {\n\t\t\t\tthis.#workspaces.delete(workspaceId);\n\t\t\t\tfor (let saved of this.#turns.get(workspaceId) ?? []) turnIds.add(saved.id);\n\t\t\t\tfor (let saved of this.#messages.get(workspaceId) ?? []) messageIds.add(saved.id);\n\t\t\t\tthis.#turns.delete(workspaceId);\n\t\t\t\tthis.#messages.delete(workspaceId);\n\t\t\t\tthis.#nextOrdinals.delete(workspaceId);\n\t\t\t\tthis.#nextSequences.delete(workspaceId);\n\t\t\t}\n\t\t\tfor (let [idempotencyKey, workspaceId] of this.#idempotency) {\n\t\t\t\tif (workspaceIds.has(workspaceId)) this.#idempotency.delete(idempotencyKey);\n\t\t\t}\n\t\t\tfor (let turnId of turnIds) this.#turnIds.delete(turnId);\n\t\t\tfor (let [requestKey, turnId] of this.#turnRequests) {\n\t\t\t\tif (turnIds.has(turnId)) this.#turnRequests.delete(requestKey);\n\t\t\t}\n\t\t\tfor (let messageId of messageIds) this.#messageIds.delete(messageId);\n\t\t\tfor (let [jobId, saved] of this.#agentMessagesByJob) {\n\t\t\t\tif (workspaceIds.has(saved.workspaceId)) this.#agentMessagesByJob.delete(jobId);\n\t\t\t}\n\t\t\tfor (let [jobId, linked] of this.#linkedJobs) {\n\t\t\t\tif (turnIds.has(linked.turnId)) this.#linkedJobs.delete(jobId);\n\t\t\t}\n\t\t});\n\t}\n\n\tasync #mutate(execute: () => Promise): Promise {\n\t\tlet previous = this.#writeTail;\n\t\tlet next = Promise.withResolvers();\n\t\tthis.#writeTail = next.promise;\n\t\tawait previous;\n\t\ttry {\n\t\t\treturn await execute();\n\t\t} finally {\n\t\t\tnext.resolve();\n\t\t}\n\t}\n\n\t#assertChannel(channelId: string, held: Lease): void {\n\t\tthis.#options.assertLease(held);\n\t\trequired(channelId, \"channel id\");\n\t\tif (!this.#options.channelExists(channelId)) {\n\t\t\tthrow missing(`channel ${channelId} does not exist`);\n\t\t}\n\t}\n\n\t#assertActiveChannel(channelId: string, held: Lease): void {\n\t\tthis.#assertChannel(channelId, held);\n\t\tif (!this.#options.channelActive(channelId)) {\n\t\t\tthrow conflict(`channel ${channelId} is archived`);\n\t\t}\n\t}\n\n\t#requireUser(userId: string): void {\n\t\tif (!this.#options.userExists(userId)) throw missing(`user ${userId} does not exist`);\n\t}\n\n\t#requireWorkspace(channelId: string, workspaceId: string): ResearchWorkspace {\n\t\tlet found = this.#workspaces.get(workspaceId);\n\t\tif (!found || found.channelId !== channelId) {\n\t\t\tthrow missing(`research workspace ${workspaceId} does not exist in channel ${channelId}`);\n\t\t}\n\t\treturn found;\n\t}\n\n\t#requireTurn(workspaceId: string, turnId: string): ResearchTurn {\n\t\tlet found = this.#turnIds.get(turnId);\n\t\tif (!found || found.workspaceId !== workspaceId) {\n\t\t\tthrow missing(`research turn ${turnId} does not exist in workspace ${workspaceId}`);\n\t\t}\n\t\treturn found;\n\t}\n\n\t#turnForRequest(workspaceId: string, requestId: string): ResearchTurn | undefined {\n\t\tlet turnId = this.#turnRequests.get(key(workspaceId, requestId));\n\t\treturn turnId ? this.#turnIds.get(turnId) : undefined;\n\t}\n\n\t#memberMessage(value: ResearchTurn): ResearchMessage {\n\t\tlet found = (this.#messages.get(value.workspaceId) ?? []).find(item =>\n\t\t\titem.turnId === value.id && item.authorKind === \"member\"\n\t\t);\n\t\tif (!found) throw new Error(`research turn ${value.id} has no member message`);\n\t\treturn found;\n\t}\n\n\t#assertNewTurn(turnId: string, messageId: string): void {\n\t\tif (this.#turnIds.has(turnId)) throw conflict(`research turn ${turnId} already exists`);\n\t\tif (this.#messageIds.has(messageId)) {\n\t\t\tthrow conflict(`research message ${messageId} already exists`);\n\t\t}\n\t}\n\n\t#newTurn(input: {\n\t\tworkspaceId: string;\n\t\tid: string;\n\t\tkind: ResearchTurn[\"kind\"];\n\t\trequestId: string;\n\t\tfingerprint: string;\n\t\tquestion: string;\n\t\trequestedBy: string;\n\t\tnow: Date;\n\t}): ResearchTurn {\n\t\tlet ordinal = this.#nextOrdinals.get(input.workspaceId) ?? 1;\n\t\tlet saved: ResearchTurn = {\n\t\t\tid: input.id,\n\t\t\tworkspaceId: input.workspaceId,\n\t\t\tordinal,\n\t\t\tkind: input.kind,\n\t\t\trequestId: input.requestId,\n\t\t\tfingerprint: input.fingerprint,\n\t\t\tquestion: input.question,\n\t\t\trequestedBy: input.requestedBy,\n\t\t\tevidenceJobId: undefined,\n\t\t\tanswerJobId: undefined,\n\t\t\tcreatedAt: new Date(input.now),\n\t\t\tupdatedAt: new Date(input.now),\n\t\t};\n\t\tthis.#turns.get(saved.workspaceId)!.push(saved);\n\t\tthis.#turnIds.set(saved.id, saved);\n\t\tthis.#turnRequests.set(key(saved.workspaceId, saved.requestId), saved.id);\n\t\tthis.#nextOrdinals.set(saved.workspaceId, ordinal + 1);\n\t\treturn saved;\n\t}\n\n\t#newMemberMessage(\n\t\tworkspaceId: string,\n\t\tmessageId: string,\n\t\tvalue: ResearchTurn,\n\t\tuserHandle: string | undefined,\n\t\tnow: Date,\n\t): ResearchMessage {\n\t\tlet sequence = this.#nextSequences.get(workspaceId) ?? 1;\n\t\tlet saved: ResearchMessage = {\n\t\t\tid: messageId,\n\t\t\tworkspaceId,\n\t\t\tsequence,\n\t\t\tturnId: value.id,\n\t\t\tauthorKind: \"member\",\n\t\t\tuserId: value.requestedBy,\n\t\t\tuserHandle,\n\t\t\ttext: value.question,\n\t\t\tsourceJobId: undefined,\n\t\t\tcreatedAt: new Date(now),\n\t\t};\n\t\tthis.#messages.get(workspaceId)!.push(saved);\n\t\tthis.#messageIds.set(saved.id, saved);\n\t\tthis.#nextSequences.set(workspaceId, sequence + 1);\n\t\treturn saved;\n\t}\n\n\t#replaceTurn(saved: ResearchTurn): void {\n\t\tlet values = this.#turns.get(saved.workspaceId)!;\n\t\tlet index = values.findIndex(value => value.id === saved.id);\n\t\tif (index < 0) throw new Error(`research turn ${saved.id} is not indexed`);\n\t\tvalues[index] = saved;\n\t\tthis.#turnIds.set(saved.id, saved);\n\t}\n\n\t#saveWorkspace(value: ResearchWorkspace, now: Date): ResearchWorkspace {\n\t\tlet saved: ResearchWorkspace = {\n\t\t\t...value,\n\t\t\trevision: value.revision + 1,\n\t\t\tupdatedAt: new Date(Math.max(value.updatedAt.getTime(), now.getTime())),\n\t\t};\n\t\tthis.#workspaces.set(saved.id, saved);\n\t\treturn saved;\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",{"_55":56,"_139":140,"_141":142,"_143":144,"_145":146,"_147":148,"_149":150},"sources",[],"viewer","meta",{"_131":132,"_133":134,"_135":136,"_43":32,"_137":14,"_138":32,"_49":50,"_51":50},"branches",[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,14,127,128,129,130],"tags",[70,71,72,73],"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","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":50,"_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,"_53":174,"_175":32,"_176":174,"_177":159},{"_168":178,"_170":179,"_15":178,"_172":180,"_53":174,"_175":32,"_176":174,"_177":50},{"_168":169,"_170":171,"_15":169,"_172":173,"_53":174,"_175":32,"_176":174,"_177":163},"id","issues","name","Issues","filters",{},true,"saved","pinnable","count","tasks","Tasks",{},"Changes",{},{"_168":158,"_170":181,"_15":158,"_172":226,"_53":174,"_175":32,"_176":174},{"_168":178,"_170":179,"_15":178,"_172":225,"_53":174,"_175":32,"_176":174},{"_168":169,"_170":171,"_15":169,"_172":224,"_53":174,"_175":32,"_176":174},{"_168":221,"_170":222,"_15":221,"_172":223,"_53":32,"_175":32,"_176":174},{"_168":218,"_170":219,"_15":218,"_172":220,"_53":32,"_175":32,"_176":174},{"_168":153,"_170":216,"_15":145,"_172":217,"_53":32,"_175":32,"_176":174},{"_168":155,"_170":213,"_15":214,"_172":215,"_53":32,"_175":32,"_176":174},{"_168":151,"_170":211,"_15":151,"_172":212,"_53":32,"_175":32,"_176":174},{"_168":207,"_170":208,"_15":209,"_172":210,"_53":32,"_175":32,"_176":174},{"_168":141,"_170":205,"_15":141,"_172":206,"_53":32,"_175":32,"_176":32},{"_168":202,"_170":203,"_15":202,"_172":204,"_53":32,"_175":32,"_176":32},{"_168":199,"_170":200,"_15":199,"_172":201,"_53":32,"_175":32,"_176":32},{"_168":196,"_170":197,"_15":196,"_172":198,"_53":32,"_175":32,"_176":32},"decisions","Decisions",{},"changelog","Changelog",{},"roadmap","Roadmap",{},"Documents",{},"activity","Activity","insights",{},"Releases",{},"Deployments","automations/deployments",{},"Workflows",{},"discussions","Discussions",{},"goals","Goals",{},{},{},{},"groups","user","agents",[],"now",1794437198721,"sidebar","expanded"]