[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10,"_11":12},"actionData","errors","root",{"_228":-5,"_231":232,"_233":234},"routes/shell",{"_40":41,"_227":-5,"_228":-5,"_229":230},"routes/repo",{"_33":-7,"_34":35,"_36":37,"_38":39,"_40":41,"_42":31,"_43":31,"_44":31,"_45":31,"_46":31,"_47":31,"_48":49,"_50":49,"_51":31,"_52":-7,"_53":-7,"_54":55,"_56":57,"_58":59,"_60":-5,"_61":62,"_63":64,"_65":66,"_67":68},"routes/repo.blob",{"_13":14,"_15":16,"_17":18,"_19":20,"_21":14,"_22":23,"_24":-5,"_25":26,"_27":28,"_28":29,"_30":31,"_32":14},"ref","1906e8f485d00a4e2d8fcbd68cb63b2c85c483b6","path","apps/server/src/storage/postgres/research.ts","oid","48123ed48c2eefaaad963f52890b6775c4de91a1","size",60876,"commit","mounts",[],"source","plain",{"_13":14,"_15":16},"kind","text","import { conflict, corrupt, missing } from \"../errors\";\nimport { deterministicChannelId } from \"../../channels/id\";\nimport {\n\tisBackgroundJobState,\n\tRESEARCH_REPOSITORY_CHANNEL_LIMIT,\n\tRESEARCH_REPOSITORY_CHANNEL_WORKSPACE_LIMIT,\n\tRESEARCH_REPOSITORY_WORKSPACE_LIMIT,\n\tresearchAttemptDisposition,\n} from \"../model\";\n\nimport type { SQL, TransactionSQL } from \"bun\";\nimport type {\n\tAppendResearchAgentMessage,\n\tAppendResearchAgentMessageResult,\n\tAppendResearchTurn,\n\tAppendResearchTurnResult,\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\tResearchMessage,\n\tResearchMessageAuthorKind,\n\tResearchTerminalRecovery,\n\tResearchTurn,\n\tResearchTurnKind,\n\tResearchWorkspace,\n\tResearchWorkspaceDetail,\n\tResearchWorkspaceOrigin,\n\tResearchWorkspaceRepositoryChannel,\n\tResearchWorkspaceRepositoryGroup,\n\tResearchWorkspaceRepositoryList,\n\tResearchWorkspaceSummary,\n\tResetInitialResearchAttempt,\n\tResetInitialResearchAttemptResult,\n\tStartResearchWorkspace,\n\tStartResearchWorkspaceResult,\n} from \"../model\";\nimport type { ResearchWorkspaceStore } from \"../port\";\n\ntype Timestamp = Date | string;\ntype Integer = bigint | number | string;\ntype Run = (action: string, execute: () => Promise) => Promise;\ntype Fence = (transaction: TransactionSQL, lease: Lease) => Promise;\ntype CreateStoredChannel = (\n\ttransaction: TransactionSQL,\n\tinput: CreateChannel,\n) => Promise;\n\ntype WorkspaceRow = {\n\tid: unknown;\n\tchannelId: unknown;\n\tpublishedChannelId: unknown;\n\ttitle: unknown;\n\tproposedQuestion: unknown;\n\tconfirmedQuery: unknown;\n\torigin: unknown;\n\toriginMessageId: unknown;\n\tinlineReference: unknown;\n\tcreatedBy: unknown;\n\tconfirmedBy: unknown;\n\trevision: unknown;\n\tidempotencyKey: unknown;\n\tfingerprint: unknown;\n\tcreatedAt: unknown;\n\tupdatedAt: unknown;\n\tnextTurnOrdinal?: unknown;\n\tnextMessageSequence?: unknown;\n};\n\ntype PublicationParentRow = {\n\tid: unknown;\n\trepositoryId: unknown;\n\trepositoryOwner: unknown;\n\trepositoryName: unknown;\n\tparentChannelId: unknown;\n\tarchivedAt: unknown;\n};\n\ntype PublicationChannelRow = {\n\tid: unknown;\n\trepositoryId: unknown;\n\trepositoryOwner: unknown;\n\trepositoryName: unknown;\n\tparentChannelId: unknown;\n\ttitle: unknown;\n\tslug: unknown;\n\tcreatedBy: unknown;\n\trevision: unknown;\n\tcreatedAt: unknown;\n\tupdatedAt: unknown;\n\tarchivedAt: unknown;\n};\n\ntype PublicationJobRow = {\n\tid: unknown;\n\ttype: unknown;\n\ttargetKey: unknown;\n\ttargetGeneration: unknown;\n\tcurrentGeneration: unknown;\n\tstate: unknown;\n\tartifactJobId: unknown;\n};\n\ntype RepositoryChannelRow = {\n\tid: unknown;\n\trepositoryId: unknown;\n\trepositoryOwner: unknown;\n\trepositoryName: unknown;\n\ttitle: unknown;\n\tslug: unknown;\n};\n\ntype TurnRow = {\n\tid: unknown;\n\tworkspaceId: unknown;\n\tordinal: unknown;\n\tkind: unknown;\n\trequestId: unknown;\n\tfingerprint: unknown;\n\tquestion: unknown;\n\trequestedBy: unknown;\n\tevidenceJobId: unknown;\n\tanswerJobId: unknown;\n\tcreatedAt: unknown;\n\tupdatedAt: unknown;\n};\n\ntype MessageRow = {\n\tid: unknown;\n\tworkspaceId: unknown;\n\tsequence: unknown;\n\tturnId: unknown;\n\tauthorKind: unknown;\n\tuserId: unknown;\n\tuserHandle: unknown;\n\ttext: unknown;\n\tsourceJobId: unknown;\n\tcreatedAt: unknown;\n};\n\ntype LinkedJobRow = {\n\tid: unknown;\n\ttype: unknown;\n\ttargetKey: unknown;\n\ttargetGeneration: unknown;\n\tcurrentGeneration: unknown;\n};\n\ntype RetryJobRow = {\n\tid: unknown;\n\tstate: unknown;\n};\n\ntype LockedWorkspace = {\n\tworkspace: ResearchWorkspace;\n\tnextTurnOrdinal: number;\n\tnextMessageSequence: number;\n};\n\nconst WORKSPACE_COLUMNS = `\n\tid,\n\tchannel_id AS \"channelId\",\n\tpublished_channel_id AS \"publishedChannelId\",\n\ttitle,\n\tproposed_question AS \"proposedQuestion\",\n\tconfirmed_query AS \"confirmedQuery\",\n\torigin,\n\torigin_message_id AS \"originMessageId\",\n\tinline_reference AS \"inlineReference\",\n\tcreated_by AS \"createdBy\",\n\tconfirmed_by AS \"confirmedBy\",\n\trevision,\n\tidempotency_key AS \"idempotencyKey\",\n\tfingerprint,\n\tcreated_at AS \"createdAt\",\n\tupdated_at AS \"updatedAt\"\n`;\n\nconst LOCKED_WORKSPACE_COLUMNS = `\n\t${WORKSPACE_COLUMNS},\n\tnext_turn_ordinal AS \"nextTurnOrdinal\",\n\tnext_message_sequence AS \"nextMessageSequence\"\n`;\n\nconst TURN_COLUMNS = `\n\tid,\n\tworkspace_id AS \"workspaceId\",\n\tordinal,\n\tkind,\n\trequest_id AS \"requestId\",\n\tfingerprint,\n\tquestion,\n\trequested_by AS \"requestedBy\",\n\tevidence_job_id AS \"evidenceJobId\",\n\tanswer_job_id AS \"answerJobId\",\n\tcreated_at AS \"createdAt\",\n\tupdated_at AS \"updatedAt\"\n`;\n\nconst QUALIFIED_TURN_COLUMNS = `\n\tresearch_turns.id,\n\tresearch_turns.workspace_id AS \"workspaceId\",\n\tresearch_turns.ordinal,\n\tresearch_turns.kind,\n\tresearch_turns.request_id AS \"requestId\",\n\tresearch_turns.fingerprint,\n\tresearch_turns.question,\n\tresearch_turns.requested_by AS \"requestedBy\",\n\tresearch_turns.evidence_job_id AS \"evidenceJobId\",\n\tresearch_turns.answer_job_id AS \"answerJobId\",\n\tresearch_turns.created_at AS \"createdAt\",\n\tresearch_turns.updated_at AS \"updatedAt\"\n`;\n\nconst MESSAGE_COLUMNS = `\n\tid,\n\tworkspace_id AS \"workspaceId\",\n\tsequence,\n\tturn_id AS \"turnId\",\n\tauthor_kind AS \"authorKind\",\n\tuser_id AS \"userId\",\n\tuser_handle AS \"userHandle\",\n\ttext,\n\tsource_job_id AS \"sourceJobId\",\n\tcreated_at AS \"createdAt\"\n`;\n\nconst PUBLICATION_CHANNEL_COLUMNS = `\n\tchannels.id,\n\tchannels.repository_id AS \"repositoryId\",\n\tchannels.repository_owner AS \"repositoryOwner\",\n\tchannels.repository_name AS \"repositoryName\",\n\tchannels.parent_channel_id AS \"parentChannelId\",\n\tchannels.title,\n\t(\n\t\tSELECT channel_slugs.slug\n\t\tFROM channel_slugs\n\t\tWHERE channel_slugs.channel_id = channels.id AND channel_slugs.canonical\n\t) AS slug,\n\tchannels.created_by AS \"createdBy\",\n\tchannels.revision,\n\tchannels.created_at AS \"createdAt\",\n\tchannels.updated_at AS \"updatedAt\",\n\tchannels.archived_at AS \"archivedAt\"\n`;\n\nconst ORIGINS = new Set([\"inline\", \"sidebar\", \"planner\"]);\nconst TURN_KINDS = new Set([\"initial\", \"follow-up\", \"search-more\"]);\nconst AUTHOR_KINDS = new Set([\"member\", \"agent\", \"system\"]);\n\nfunction required(value: unknown, field: string): string {\n\tif (typeof value !== \"string\" || !value) throw conflict(`research ${field} must not be empty`);\n\treturn value;\n}\n\nfunction optionalInput(value: unknown, field: string): string | undefined {\n\treturn value === undefined ? undefined : required(value, field);\n}\n\nfunction text(value: unknown, field: string): string {\n\tif (typeof value !== \"string\" || !value) throw corrupt(`storage returned an invalid ${field}`);\n\treturn value;\n}\n\nfunction optionalText(value: unknown, field: string): string | undefined {\n\treturn value === null || value === undefined ? undefined : text(value, field);\n}\n\nfunction date(value: unknown, field: string): Date {\n\tif (!(value instanceof Date) && typeof value !== \"string\") {\n\t\tthrow corrupt(`storage returned an invalid ${field}`);\n\t}\n\tlet parsed = new Date(value as Timestamp);\n\tif (Number.isNaN(parsed.getTime())) throw corrupt(`storage returned an invalid ${field}`);\n\treturn parsed;\n}\n\nfunction inputDate(value: unknown, 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 integer(value: unknown, field: string): number {\n\tif (typeof value !== \"bigint\" && typeof value !== \"number\" && typeof value !== \"string\") {\n\t\tthrow corrupt(`storage returned an invalid ${field}`);\n\t}\n\tlet parsed = typeof value === \"number\" ? value : Number(value as Integer);\n\tif (!Number.isSafeInteger(parsed) || parsed < 0) {\n\t\tthrow corrupt(`storage returned an invalid ${field}`);\n\t}\n\treturn parsed;\n}\n\nfunction workspace(row: WorkspaceRow): ResearchWorkspace {\n\tlet id = text(row.id, \"research workspace id\");\n\tlet confirmedQuery = optionalText(row.confirmedQuery, \"research workspace confirmed query\");\n\tlet confirmedBy = optionalText(row.confirmedBy, \"research workspace confirming member\");\n\tif ((confirmedQuery === undefined) !== (confirmedBy === undefined)) {\n\t\tthrow corrupt(`research workspace ${id} has inconsistent confirmation data`);\n\t}\n\tif (!ORIGINS.has(row.origin as ResearchWorkspaceOrigin)) {\n\t\tthrow corrupt(`research workspace ${id} has an invalid origin`);\n\t}\n\tlet revision = integer(row.revision, \"research workspace revision\");\n\tlet inlineReference = row.inlineReference === null ? undefined : row.inlineReference;\n\tif (\n\t\tinlineReference !== undefined && inlineReference !== \"pending\" && inlineReference !== \"placed\"\n\t) {\n\t\tthrow corrupt(`research workspace ${id} has an invalid inline reference state`);\n\t}\n\tif (inlineReference && (row.origin !== \"planner\" || !row.originMessageId)) {\n\t\tthrow corrupt(`research workspace ${id} has an invalid inline reference origin`);\n\t}\n\tlet createdAt = date(row.createdAt, \"research workspace creation time\");\n\tlet updatedAt = date(row.updatedAt, \"research workspace update time\");\n\tif (updatedAt < createdAt) throw corrupt(`research workspace ${id} has invalid timestamps`);\n\treturn {\n\t\tid,\n\t\tchannelId: text(row.channelId, \"research workspace channel id\"),\n\t\tpublishedChannelId: optionalText(\n\t\t\trow.publishedChannelId,\n\t\t\t\"research workspace published channel id\",\n\t\t),\n\t\ttitle: text(row.title, \"research workspace title\"),\n\t\tproposedQuestion: text(row.proposedQuestion, \"research workspace proposed question\"),\n\t\tconfirmedQuery,\n\t\torigin: row.origin as ResearchWorkspaceOrigin,\n\t\toriginMessageId: optionalText(row.originMessageId, \"research workspace origin message id\"),\n\t\t...(inlineReference ? { inlineReference } : {}),\n\t\tcreatedBy: text(row.createdBy, \"research workspace creating member\"),\n\t\tconfirmedBy,\n\t\trevision,\n\t\tidempotencyKey: text(row.idempotencyKey, \"research workspace idempotency key\"),\n\t\tfingerprint: text(row.fingerprint, \"research workspace fingerprint\"),\n\t\tcreatedAt,\n\t\tupdatedAt,\n\t};\n}\n\nfunction publicationChannel(row: PublicationChannelRow): ChannelRecord {\n\tlet archivedAt = row.archivedAt === null\n\t\t? undefined\n\t\t: date(row.archivedAt, \"published channel archive time\");\n\tlet parentChannelId = optionalText(row.parentChannelId, \"published channel parent id\");\n\treturn {\n\t\tid: text(row.id, \"published channel id\"),\n\t\trepositoryId: text(row.repositoryId, \"published channel repository id\"),\n\t\trepositoryOwner: text(row.repositoryOwner, \"published channel repository owner\"),\n\t\trepositoryName: text(row.repositoryName, \"published channel repository name\"),\n\t\t...(parentChannelId ? { parentChannelId } : {}),\n\t\ttitle: text(row.title, \"published channel title\"),\n\t\tslug: text(row.slug, \"published channel slug\"),\n\t\tcreatedBy: text(row.createdBy, \"published channel creator\"),\n\t\trevision: integer(row.revision, \"published channel revision\"),\n\t\tcreatedAt: date(row.createdAt, \"published channel creation time\"),\n\t\tupdatedAt: date(row.updatedAt, \"published channel update time\"),\n\t\t...(archivedAt ? { archivedAt } : {}),\n\t};\n}\n\nfunction repositoryChannel(row: RepositoryChannelRow): ResearchWorkspaceRepositoryChannel {\n\treturn {\n\t\tid: text(row.id, \"research repository channel id\"),\n\t\trepositoryId: text(row.repositoryId, \"research repository id\"),\n\t\trepositoryOwner: text(row.repositoryOwner, \"research repository owner\"),\n\t\trepositoryName: text(row.repositoryName, \"research repository name\"),\n\t\ttitle: text(row.title, \"research repository channel title\"),\n\t\tslug: text(row.slug, \"research repository channel slug\"),\n\t};\n}\n\nfunction lockedWorkspace(row: WorkspaceRow): LockedWorkspace {\n\tlet nextTurnOrdinal = integer(row.nextTurnOrdinal, \"research workspace next turn ordinal\");\n\tlet nextMessageSequence = integer(\n\t\trow.nextMessageSequence,\n\t\t\"research workspace next message sequence\",\n\t);\n\tif (nextTurnOrdinal < 1 || nextMessageSequence < 1) {\n\t\tthrow corrupt(`research workspace ${String(row.id)} has invalid next counters`);\n\t}\n\treturn { workspace: workspace(row), nextTurnOrdinal, nextMessageSequence };\n}\n\nfunction turn(row: TurnRow): ResearchTurn {\n\tlet id = text(row.id, \"research turn id\");\n\tif (!TURN_KINDS.has(row.kind as ResearchTurnKind)) {\n\t\tthrow corrupt(`research turn ${id} has an invalid kind`);\n\t}\n\tlet ordinal = integer(row.ordinal, \"research turn ordinal\");\n\tif (ordinal < 1) throw corrupt(`research turn ${id} has an invalid ordinal`);\n\tlet evidenceJobId = optionalText(row.evidenceJobId, \"research evidence job id\");\n\tlet answerJobId = optionalText(row.answerJobId, \"research answer job id\");\n\tif (evidenceJobId !== undefined && evidenceJobId === answerJobId) {\n\t\tthrow corrupt(`research turn ${id} uses one job for two roles`);\n\t}\n\tlet createdAt = date(row.createdAt, \"research turn creation time\");\n\tlet updatedAt = date(row.updatedAt, \"research turn update time\");\n\tif (updatedAt < createdAt) throw corrupt(`research turn ${id} has invalid timestamps`);\n\treturn {\n\t\tid,\n\t\tworkspaceId: text(row.workspaceId, \"research turn workspace id\"),\n\t\tordinal,\n\t\tkind: row.kind as ResearchTurnKind,\n\t\trequestId: text(row.requestId, \"research turn request id\"),\n\t\tfingerprint: text(row.fingerprint, \"research turn fingerprint\"),\n\t\tquestion: text(row.question, \"research turn question\"),\n\t\trequestedBy: text(row.requestedBy, \"research turn requesting member\"),\n\t\tevidenceJobId,\n\t\tanswerJobId,\n\t\tcreatedAt,\n\t\tupdatedAt,\n\t};\n}\n\nfunction message(row: MessageRow): ResearchMessage {\n\tlet id = text(row.id, \"research message id\");\n\tif (!AUTHOR_KINDS.has(row.authorKind as ResearchMessageAuthorKind)) {\n\t\tthrow corrupt(`research message ${id} has an invalid author kind`);\n\t}\n\tlet sequence = integer(row.sequence, \"research message sequence\");\n\tif (sequence < 1) throw corrupt(`research message ${id} has an invalid sequence`);\n\tlet authorKind = row.authorKind as ResearchMessageAuthorKind;\n\tlet turnId = optionalText(row.turnId, \"research message turn id\");\n\tlet sourceJobId = optionalText(row.sourceJobId, \"research message source job id\");\n\tif (authorKind === \"member\" && (!turnId || sourceJobId)) {\n\t\tthrow corrupt(`research member message ${id} has invalid linkage`);\n\t}\n\tif (authorKind === \"agent\" && (!turnId || !sourceJobId)) {\n\t\tthrow corrupt(`research agent message ${id} has invalid linkage`);\n\t}\n\treturn {\n\t\tid,\n\t\tworkspaceId: text(row.workspaceId, \"research message workspace id\"),\n\t\tsequence,\n\t\tturnId,\n\t\tauthorKind,\n\t\tuserId: optionalText(row.userId, \"research message user id\"),\n\t\tuserHandle: optionalText(row.userHandle, \"research message user handle\"),\n\t\ttext: text(row.text, \"research message text\"),\n\t\tsourceJobId,\n\t\tcreatedAt: date(row.createdAt, \"research message creation time\"),\n\t};\n}\n\nfunction same(left: string | undefined, right: string | undefined): boolean {\n\treturn left === right;\n}\n\n/** PostgreSQL research workspaces, turns, transcript messages, and job linkage. */\nexport class PostgresResearchWorkspaceStore implements ResearchWorkspaceStore {\n\t#sql: SQL;\n\t#run: Run;\n\t#fence: Fence;\n\t#createChannel: CreateStoredChannel;\n\n\tconstructor(sql: SQL, run: Run, fence: Fence, createChannel: CreateStoredChannel) {\n\t\tthis.#sql = sql;\n\t\tthis.#run = run;\n\t\tthis.#fence = fence;\n\t\tthis.#createChannel = createChannel;\n\t}\n\n\treadonly create = (input: CreateResearchWorkspace): Promise =>\n\t\tthis.#run(\"create research workspace\", () =>\n\t\t\tthis.#sql.begin(async transaction => {\n\t\t\t\tawait this.#fence(transaction, input.lease);\n\t\t\t\tlet channelId = required(input.channelId, \"channel id\");\n\t\t\t\tlet idempotencyKey = required(input.idempotencyKey, \"workspace idempotency key\");\n\t\t\t\tlet fingerprint = required(input.fingerprint, \"workspace fingerprint\");\n\t\t\t\tlet archived = await this.#lockChannelArchiveState(transaction, channelId);\n\t\t\t\tlet [existing] = await transaction`\n\t\t\t\t\tSELECT ${transaction.unsafe(WORKSPACE_COLUMNS)}\n\t\t\t\t\tFROM research_workspaces\n\t\t\t\t\tWHERE channel_id = ${channelId} AND idempotency_key = ${idempotencyKey}\n\t\t\t\t\tFOR UPDATE\n\t\t\t\t`;\n\t\t\t\tif (existing) {\n\t\t\t\t\tlet repeated = workspace(existing);\n\t\t\t\t\tif (repeated.fingerprint !== fingerprint) {\n\t\t\t\t\t\tthrow conflict(`research workspace idempotency key ${idempotencyKey} was reused`);\n\t\t\t\t\t}\n\t\t\t\t\treturn { workspace: repeated, repeated: true };\n\t\t\t\t}\n\t\t\t\tif (archived) throw conflict(`channel ${channelId} is archived`);\n\n\t\t\t\tlet id = required(input.id, \"workspace id\");\n\t\t\t\tlet title = required(input.title, \"workspace title\");\n\t\t\t\tlet proposedQuestion = required(input.proposedQuestion, \"workspace proposed question\");\n\t\t\t\tlet createdBy = required(input.createdBy, \"creating member id\");\n\t\t\t\tlet originMessageId = optionalInput(\n\t\t\t\t\tinput.originMessageId,\n\t\t\t\t\t\"workspace origin message id\",\n\t\t\t\t);\n\t\t\t\tif (!ORIGINS.has(input.origin)) throw conflict(\"research workspace origin is invalid\");\n\t\t\t\tlet now = inputDate(input.now, \"workspace creation time\");\n\t\t\t\tlet [saved] = await transaction`\n\t\t\t\t\tINSERT INTO research_workspaces (\n\t\t\t\t\t\tid, channel_id, title, proposed_question, origin, origin_message_id,\n\t\t\t\t\t\tcreated_by, revision, next_turn_ordinal, next_message_sequence,\n\t\t\t\t\t\tidempotency_key, fingerprint, created_at, updated_at\n\t\t\t\t\t) VALUES (\n\t\t\t\t\t\t${id}, ${channelId}, ${title}, ${proposedQuestion}, ${input.origin},\n\t\t\t\t\t\t${originMessageId ?? null}, ${createdBy}, 0, 1, 1,\n\t\t\t\t\t\t${idempotencyKey}, ${fingerprint}, ${now}, ${now}\n\t\t\t\t\t)\n\t\t\t\t\tRETURNING ${transaction.unsafe(WORKSPACE_COLUMNS)}\n\t\t\t\t`;\n\t\t\t\tif (!saved) throw corrupt(\"creating a research workspace returned no record\");\n\t\t\t\treturn { workspace: workspace(saved), repeated: false };\n\t\t\t}));\n\n\treadonly start = (\n\t\tinput: StartResearchWorkspace,\n\t): Promise =>\n\t\tthis.#run(\"start research workspace\", () =>\n\t\t\tthis.#sql.begin(async transaction => {\n\t\t\t\tawait this.#fence(transaction, input.lease);\n\t\t\t\tlet channelId = required(input.channelId, \"channel id\");\n\t\t\t\tlet idempotencyKey = required(input.idempotencyKey, \"workspace idempotency key\");\n\t\t\t\tlet fingerprint = required(input.fingerprint, \"workspace fingerprint\");\n\t\t\t\tif (input.origin !== \"inline\" && input.origin !== \"planner\") {\n\t\t\t\t\tthrow conflict(\"research workspace start origin is invalid\");\n\t\t\t\t}\n\t\t\t\tif (input.inlineReference && input.origin !== \"planner\") {\n\t\t\t\t\tthrow conflict(\"inline reference requires Planner origin\");\n\t\t\t\t}\n\t\t\t\tlet originMessageId = optionalInput(\n\t\t\t\t\tinput.originMessageId,\n\t\t\t\t\t\"workspace origin message id\",\n\t\t\t\t);\n\t\t\t\tif (\n\t\t\t\t\tinput.origin === \"inline\" && originMessageId !== undefined\n\t\t\t\t\t|| input.origin === \"planner\" && originMessageId === undefined\n\t\t\t\t) throw conflict(\"research workspace start origin message is invalid\");\n\t\t\t\tlet archived = await this.#lockChannelArchiveState(transaction, channelId);\n\t\t\t\tlet [existing] = await transaction`\n\t\t\t\t\tSELECT ${transaction.unsafe(WORKSPACE_COLUMNS)}\n\t\t\t\t\tFROM research_workspaces\n\t\t\t\t\tWHERE channel_id = ${channelId} AND idempotency_key = ${idempotencyKey}\n\t\t\t\t\tFOR UPDATE\n\t\t\t\t`;\n\t\t\t\tif (existing) {\n\t\t\t\t\tlet repeated = workspace(existing);\n\t\t\t\t\tlet [turnRow] = await transaction`\n\t\t\t\t\t\tSELECT ${transaction.unsafe(TURN_COLUMNS)}\n\t\t\t\t\t\tFROM research_turns\n\t\t\t\t\t\tWHERE workspace_id = ${repeated.id} AND ordinal = 1\n\t\t\t\t\t`;\n\t\t\t\t\tlet repeatedTurn = turnRow ? turn(turnRow) : undefined;\n\t\t\t\t\tif (\n\t\t\t\t\t\trepeated.fingerprint !== fingerprint\n\t\t\t\t\t\t|| repeated.origin !== input.origin\n\t\t\t\t\t\t|| repeated.originMessageId !== originMessageId\n\t\t\t\t\t\t|| !repeatedTurn\n\t\t\t\t\t\t|| repeatedTurn.kind !== \"initial\"\n\t\t\t\t\t) {\n\t\t\t\t\t\tthrow conflict(\n\t\t\t\t\t\t\t`research workspace idempotency key ${idempotencyKey} was reused`,\n\t\t\t\t\t\t);\n\t\t\t\t\t}\n\t\t\t\t\tif (input.inlineReference && !repeated.inlineReference) {\n\t\t\t\t\t\tlet [upgraded] = await transaction`\n\t\t\t\t\t\t\tUPDATE research_workspaces SET inline_reference = 'pending'\n\t\t\t\t\t\t\tWHERE id = ${repeated.id}\n\t\t\t\t\t\t\tRETURNING ${transaction.unsafe(WORKSPACE_COLUMNS)}\n\t\t\t\t\t\t`;\n\t\t\t\t\t\tif (!upgraded) throw corrupt(\"research reference upgrade returned no record\");\n\t\t\t\t\t\trepeated = workspace(upgraded);\n\t\t\t\t\t}\n\t\t\t\t\treturn {\n\t\t\t\t\t\tworkspace: repeated,\n\t\t\t\t\t\tturn: repeatedTurn,\n\t\t\t\t\t\tmessage: await this.#memberMessage(transaction, repeatedTurn),\n\t\t\t\t\t\trepeated: true,\n\t\t\t\t\t};\n\t\t\t\t}\n\t\t\t\tif (archived) throw conflict(`channel ${channelId} is archived`);\n\t\t\t\tlet workspaceId = required(input.id, \"workspace id\");\n\t\t\t\tlet title = required(input.title, \"workspace title\");\n\t\t\t\tlet question = required(input.question, \"workspace question\");\n\t\t\t\tlet createdBy = required(input.createdBy, \"creating member id\");\n\t\t\t\tlet createdByHandle = optionalInput(\n\t\t\t\t\tinput.createdByHandle,\n\t\t\t\t\t\"creating member handle\",\n\t\t\t\t);\n\t\t\t\tlet requestId = required(input.requestId, \"request id\");\n\t\t\t\tlet now = inputDate(input.now, \"workspace start time\");\n\t\t\t\tlet [savedWorkspaceRow] = await transaction`\n\t\t\t\t\tINSERT INTO research_workspaces (\n\t\t\t\t\t\tid, channel_id, title, proposed_question, confirmed_query, origin,\n\t\t\t\t\t\torigin_message_id,\n\t\t\t\t\t\tinline_reference,\n\t\t\t\t\t\tcreated_by, confirmed_by, revision, next_turn_ordinal,\n\t\t\t\t\t\tnext_message_sequence, idempotency_key, fingerprint, created_at, updated_at\n\t\t\t\t\t) VALUES (\n\t\t\t\t\t\t${workspaceId}, ${channelId}, ${title}, ${question}, ${question},\n\t\t\t\t\t\t${input.origin}, ${originMessageId ?? null}, ${input.inlineReference ?? null},\n\t\t\t\t\t\t${createdBy}, ${createdBy}, 0, 2, 2, ${idempotencyKey}, ${fingerprint},\n\t\t\t\t\t\t${now}, ${now}\n\t\t\t\t\t)\n\t\t\t\t\tRETURNING ${transaction.unsafe(WORKSPACE_COLUMNS)}\n\t\t\t\t`;\n\t\t\t\tif (!savedWorkspaceRow) {\n\t\t\t\t\tthrow corrupt(\"starting a research workspace returned no record\");\n\t\t\t\t}\n\t\t\t\tlet savedTurn = await this.#insertTurn(transaction, {\n\t\t\t\t\tid: required(input.turnId, \"turn id\"),\n\t\t\t\t\tworkspaceId,\n\t\t\t\t\tordinal: 1,\n\t\t\t\t\tkind: \"initial\",\n\t\t\t\t\trequestId,\n\t\t\t\t\tfingerprint,\n\t\t\t\t\tquestion,\n\t\t\t\t\trequestedBy: createdBy,\n\t\t\t\t\tnow,\n\t\t\t\t});\n\t\t\t\tlet savedMessage = await this.#insertMemberMessage(\n\t\t\t\t\ttransaction,\n\t\t\t\t\tworkspaceId,\n\t\t\t\t\t1,\n\t\t\t\t\trequired(input.messageId, \"message id\"),\n\t\t\t\t\tsavedTurn,\n\t\t\t\t\tcreatedByHandle,\n\t\t\t\t\tnow,\n\t\t\t\t);\n\t\t\t\treturn {\n\t\t\t\t\tworkspace: workspace(savedWorkspaceRow),\n\t\t\t\t\tturn: savedTurn,\n\t\t\t\t\tmessage: savedMessage,\n\t\t\t\t\trepeated: false,\n\t\t\t\t};\n\t\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.#run(\"mark research reference placed\", () =>\n\t\t\tthis.#sql.begin(async transaction => {\n\t\t\t\tawait this.#fence(transaction, input.lease);\n\t\t\t\tlet [placed] = await transaction<{ id: string }[]>`\n\t\t\t\t\tUPDATE research_workspaces SET inline_reference = 'placed'\n\t\t\t\t\tWHERE channel_id = ${input.channelId} AND id = ${input.workspaceId}\n\t\t\t\t\t\tAND inline_reference IS NOT NULL\n\t\t\t\t\tRETURNING id\n\t\t\t\t`;\n\t\t\t\tif (!placed) throw conflict(\"research reference placement is not required\");\n\t\t\t}));\n\n\treadonly listReferenceRecovery = (\n\t\tlimit: number,\n\t\tafterId?: string,\n\t\tchannelId?: string,\n\t): Promise =>\n\t\tthis.#run(\"list research reference recovery\", async () => {\n\t\t\tlet rows = await this.#sql`\n\t\t\t\tSELECT ${this.#sql.unsafe(WORKSPACE_COLUMNS)}\n\t\t\t\tFROM research_workspaces\n\t\t\t\tWHERE (${afterId ?? \"\"} = '' OR id > ${afterId ?? \"\"})\n\t\t\t\t\tAND (${channelId ?? \"\"} = '' OR channel_id = ${channelId ?? \"\"})\n\t\t\t\t\tAND (inline_reference = 'pending' OR inline_reference = 'placed'\n\t\t\t\t\t\tAND NOT EXISTS (\n\t\t\t\t\t\t\tSELECT 1 FROM research_turns\n\t\t\t\t\t\t\tWHERE workspace_id = research_workspaces.id AND ordinal = 1\n\t\t\t\t\t\t\t\tAND evidence_job_id IS NOT NULL\n\t\t\t\t\t\t))\n\t\t\t\tORDER BY id ASC\n\t\t\t\tLIMIT ${Math.min(100, Math.max(1, limit))}\n\t\t\t`;\n\t\t\treturn rows.map(workspace);\n\t\t});\n\n\treadonly listTerminalRecovery = (\n\t\tlimit: number,\n\t\tafterId?: string,\n\t\tchannelId?: string,\n\t): Promise =>\n\t\tthis.#run(\"list research terminal recovery\", async () => {\n\t\t\tlet rows = await this.#sql<{ id: string; channelId: string; jobId: string }[]>`\n\t\t\t\tSELECT research_workspaces.id,\n\t\t\t\t\tresearch_workspaces.channel_id AS \"channelId\",\n\t\t\t\t\tCASE\n\t\t\t\t\t\tWHEN answer.state = 'failed' OR\n\t\t\t\t\t\t\t(answer.state = 'completed' AND published_channel_id IS NOT NULL)\n\t\t\t\t\t\t\tTHEN answer.id\n\t\t\t\t\t\tELSE evidence.id\n\t\t\t\t\tEND AS \"jobId\"\n\t\t\t\tFROM research_workspaces\n\t\t\t\tJOIN research_turns initial ON initial.workspace_id = research_workspaces.id\n\t\t\t\t\tAND initial.kind = 'initial'\n\t\t\t\tLEFT JOIN background_jobs answer ON answer.id = initial.answer_job_id\n\t\t\t\t\tAND answer.channel_id = research_workspaces.channel_id\n\t\t\t\tLEFT JOIN background_jobs evidence ON evidence.id = initial.evidence_job_id\n\t\t\t\t\tAND evidence.channel_id = research_workspaces.channel_id\n\t\t\t\tWHERE research_workspaces.origin = 'planner'\n\t\t\t\t\tAND research_workspaces.inline_reference = 'placed'\n\t\t\t\t\tAND (${afterId ?? \"\"} = '' OR research_workspaces.id > ${afterId ?? \"\"})\n\t\t\t\t\tAND (${channelId ?? \"\"} = '' OR research_workspaces.channel_id = ${channelId ?? \"\"})\n\t\t\t\t\tAND (answer.state = 'failed'\n\t\t\t\t\t\tOR answer.state = 'completed' AND published_channel_id IS NOT NULL\n\t\t\t\t\t\tOR evidence.state = 'failed')\n\t\t\t\tORDER BY research_workspaces.id ASC\n\t\t\t\tLIMIT ${Math.min(100, Math.max(1, limit))}\n\t\t\t`;\n\t\t\treturn rows;\n\t\t});\n\n\treadonly confirm = (\n\t\tinput: ConfirmResearchWorkspace,\n\t): Promise =>\n\t\tthis.#run(\"confirm research workspace\", () =>\n\t\t\tthis.#sql.begin(async transaction => {\n\t\t\t\tawait this.#fence(transaction, input.lease);\n\t\t\t\tlet channelId = required(input.channelId, \"channel id\");\n\t\t\t\tlet workspaceId = required(input.workspaceId, \"workspace id\");\n\t\t\t\tlet requestId = required(input.requestId, \"confirmation request id\");\n\t\t\t\tlet fingerprint = required(input.fingerprint, \"confirmation fingerprint\");\n\t\t\t\tlet confirmedQuery = required(input.confirmedQuery, \"confirmed query\");\n\t\t\t\tlet confirmedBy = required(input.confirmedBy, \"confirming member id\");\n\t\t\t\tlet confirmedByHandle = optionalInput(\n\t\t\t\t\tinput.confirmedByHandle,\n\t\t\t\t\t\"confirming member handle\",\n\t\t\t\t);\n\t\t\t\tlet archived = await this.#lockChannelArchiveState(transaction, channelId);\n\t\t\t\tlet locked = await this.#lockWorkspace(transaction, channelId, workspaceId);\n\t\t\t\tlet repeated = await this.#turnForRequest(transaction, workspaceId, requestId);\n\t\t\t\tif (repeated) {\n\t\t\t\t\tlet repeatedMessage = await this.#memberMessage(transaction, repeated);\n\t\t\t\t\tif (\n\t\t\t\t\t\trepeated.kind !== \"initial\"\n\t\t\t\t\t\t|| repeated.fingerprint !== fingerprint\n\t\t\t\t\t\t|| repeated.question !== confirmedQuery\n\t\t\t\t\t\t|| repeated.requestedBy !== confirmedBy\n\t\t\t\t\t\t|| !same(repeatedMessage.userHandle, confirmedByHandle)\n\t\t\t\t\t) throw conflict(`research request ${requestId} was reused with another payload`);\n\t\t\t\t\treturn {\n\t\t\t\t\t\tworkspace: locked.workspace,\n\t\t\t\t\t\tturn: repeated,\n\t\t\t\t\t\tmessage: repeatedMessage,\n\t\t\t\t\t\trepeated: true,\n\t\t\t\t\t};\n\t\t\t\t}\n\t\t\t\tif (archived) throw conflict(`channel ${channelId} is archived`);\n\t\t\t\tif (locked.workspace.confirmedQuery !== undefined) {\n\t\t\t\t\tthrow conflict(`research workspace ${workspaceId} is already confirmed`);\n\t\t\t\t}\n\t\t\t\tlet turnId = required(input.turnId, \"turn id\");\n\t\t\t\tlet messageId = required(input.messageId, \"message id\");\n\t\t\t\tlet now = inputDate(input.now, \"confirmation time\");\n\t\t\t\tlet savedTurn = await this.#insertTurn(transaction, {\n\t\t\t\t\tid: turnId,\n\t\t\t\t\tworkspaceId,\n\t\t\t\t\tordinal: locked.nextTurnOrdinal,\n\t\t\t\t\tkind: \"initial\",\n\t\t\t\t\trequestId,\n\t\t\t\t\tfingerprint,\n\t\t\t\t\tquestion: confirmedQuery,\n\t\t\t\t\trequestedBy: confirmedBy,\n\t\t\t\t\tnow,\n\t\t\t\t});\n\t\t\t\tlet savedMessage = await this.#insertMemberMessage(\n\t\t\t\t\ttransaction,\n\t\t\t\t\tworkspaceId,\n\t\t\t\t\tlocked.nextMessageSequence,\n\t\t\t\t\tmessageId,\n\t\t\t\t\tsavedTurn,\n\t\t\t\t\tconfirmedByHandle,\n\t\t\t\t\tnow,\n\t\t\t\t);\n\t\t\t\tlet [savedWorkspace] = await transaction`\n\t\t\t\t\tUPDATE research_workspaces SET\n\t\t\t\t\t\tconfirmed_query = ${confirmedQuery},\n\t\t\t\t\t\tconfirmed_by = ${confirmedBy},\n\t\t\t\t\t\trevision = revision + 1,\n\t\t\t\t\t\tnext_turn_ordinal = next_turn_ordinal + 1,\n\t\t\t\t\t\tnext_message_sequence = next_message_sequence + 1,\n\t\t\t\t\t\tupdated_at = GREATEST(updated_at, ${now})\n\t\t\t\t\tWHERE id = ${workspaceId}\n\t\t\t\t\tRETURNING ${transaction.unsafe(WORKSPACE_COLUMNS)}\n\t\t\t\t`;\n\t\t\t\tif (!savedWorkspace) throw corrupt(\"confirming a research workspace returned no record\");\n\t\t\t\treturn {\n\t\t\t\t\tworkspace: workspace(savedWorkspace),\n\t\t\t\t\tturn: savedTurn,\n\t\t\t\t\tmessage: savedMessage,\n\t\t\t\t\trepeated: false,\n\t\t\t\t};\n\t\t\t}));\n\n\treadonly appendTurn = (input: AppendResearchTurn): Promise =>\n\t\tthis.#run(\"append research turn\", () =>\n\t\t\tthis.#sql.begin(async transaction => {\n\t\t\t\tawait this.#fence(transaction, input.lease);\n\t\t\t\tlet channelId = required(input.channelId, \"channel id\");\n\t\t\t\tlet workspaceId = required(input.workspaceId, \"workspace id\");\n\t\t\t\tlet requestId = required(input.requestId, \"turn request id\");\n\t\t\t\tlet fingerprint = required(input.fingerprint, \"turn fingerprint\");\n\t\t\t\tlet question = required(input.question, \"turn question\");\n\t\t\t\tlet requestedBy = required(input.requestedBy, \"requesting member id\");\n\t\t\t\tlet requestedByHandle = optionalInput(\n\t\t\t\t\tinput.requestedByHandle,\n\t\t\t\t\t\"requesting member handle\",\n\t\t\t\t);\n\t\t\t\tif (input.kind !== \"follow-up\" && input.kind !== \"search-more\") {\n\t\t\t\t\tthrow conflict(\"research appended turn kind is invalid\");\n\t\t\t\t}\n\t\t\t\tlet archived = await this.#lockChannelArchiveState(transaction, channelId);\n\t\t\t\tlet locked = await this.#lockWorkspace(transaction, channelId, workspaceId);\n\t\t\t\tlet repeated = await this.#turnForRequest(transaction, workspaceId, requestId);\n\t\t\t\tif (repeated) {\n\t\t\t\t\tlet repeatedMessage = await this.#memberMessage(transaction, repeated);\n\t\t\t\t\tif (\n\t\t\t\t\t\trepeated.kind !== input.kind\n\t\t\t\t\t\t|| repeated.fingerprint !== fingerprint\n\t\t\t\t\t\t|| repeated.question !== question\n\t\t\t\t\t\t|| repeated.requestedBy !== requestedBy\n\t\t\t\t\t\t|| !same(repeatedMessage.userHandle, requestedByHandle)\n\t\t\t\t\t) throw conflict(`research request ${requestId} was reused with another payload`);\n\t\t\t\t\treturn {\n\t\t\t\t\t\tworkspace: locked.workspace,\n\t\t\t\t\t\tturn: repeated,\n\t\t\t\t\t\tmessage: repeatedMessage,\n\t\t\t\t\t\trepeated: true,\n\t\t\t\t\t};\n\t\t\t\t}\n\t\t\t\tif (archived) throw conflict(`channel ${channelId} is archived`);\n\t\t\t\tif (locked.workspace.confirmedQuery === undefined) {\n\t\t\t\t\tthrow conflict(`research workspace ${workspaceId} is not confirmed`);\n\t\t\t\t}\n\t\t\t\tlet now = inputDate(input.now, \"turn creation time\");\n\t\t\t\tlet savedTurn = await this.#insertTurn(transaction, {\n\t\t\t\t\tid: required(input.turnId, \"turn id\"),\n\t\t\t\t\tworkspaceId,\n\t\t\t\t\tordinal: locked.nextTurnOrdinal,\n\t\t\t\t\tkind: input.kind,\n\t\t\t\t\trequestId,\n\t\t\t\t\tfingerprint,\n\t\t\t\t\tquestion,\n\t\t\t\t\trequestedBy,\n\t\t\t\t\tnow,\n\t\t\t\t});\n\t\t\t\tlet savedMessage = await this.#insertMemberMessage(\n\t\t\t\t\ttransaction,\n\t\t\t\t\tworkspaceId,\n\t\t\t\t\tlocked.nextMessageSequence,\n\t\t\t\t\trequired(input.messageId, \"message id\"),\n\t\t\t\t\tsavedTurn,\n\t\t\t\t\trequestedByHandle,\n\t\t\t\t\tnow,\n\t\t\t\t);\n\t\t\t\tlet savedWorkspace = await this.#bumpWorkspace(transaction, workspaceId, now, 1, 1);\n\t\t\t\treturn {\n\t\t\t\t\tworkspace: savedWorkspace,\n\t\t\t\t\tturn: savedTurn,\n\t\t\t\t\tmessage: savedMessage,\n\t\t\t\t\trepeated: false,\n\t\t\t\t};\n\t\t\t}));\n\n\treadonly linkJob = (input: LinkResearchTurnJob): Promise =>\n\t\tthis.#run(\"link research job\", () =>\n\t\t\tthis.#sql.begin(async transaction => {\n\t\t\t\tawait this.#fence(transaction, input.lease);\n\t\t\t\tlet channelId = required(input.channelId, \"channel id\");\n\t\t\t\tlet workspaceId = required(input.workspaceId, \"workspace id\");\n\t\t\t\tlet turnId = required(input.turnId, \"turn id\");\n\t\t\t\tlet jobId = required(input.jobId, \"linked job id\");\n\t\t\t\tif (input.role !== \"evidence\" && input.role !== \"answer\") {\n\t\t\t\t\tthrow conflict(\"research job role is invalid\");\n\t\t\t\t}\n\t\t\t\tlet locked = await this.#lockWorkspace(transaction, channelId, workspaceId);\n\t\t\t\tlet foundTurn = await this.#lockTurn(transaction, workspaceId, turnId);\n\t\t\t\tlet [job] = await transaction`\n\t\t\t\t\tSELECT jobs.id, jobs.type, jobs.target_key AS \"targetKey\",\n\t\t\t\t\t\tjobs.target_generation AS \"targetGeneration\",\n\t\t\t\t\t\ttargets.generation AS \"currentGeneration\"\n\t\t\t\t\tFROM background_jobs AS jobs\n\t\t\t\t\tJOIN background_job_targets AS targets\n\t\t\t\t\t\tON targets.channel_id = jobs.channel_id\n\t\t\t\t\t\tAND targets.target_key = jobs.target_key\n\t\t\t\t\tWHERE jobs.id = ${jobId} AND jobs.channel_id = ${channelId}\n\t\t\t\t`;\n\t\t\t\tif (!job) {\n\t\t\t\t\tthrow missing(`background job ${jobId} does not exist in channel ${channelId}`);\n\t\t\t\t}\n\t\t\t\tlet type = input.role === \"evidence\" ? \"research-evidence\" : \"research-answer\";\n\t\t\t\tlet target = `${type}:workspace:${workspaceId}:turn:${turnId}:${input.role}`;\n\t\t\t\tif (\n\t\t\t\t\ttext(job.type, \"research linked job type\") !== type\n\t\t\t\t\t|| text(job.targetKey, \"research linked job target\") !== target\n\t\t\t\t\t|| integer(job.targetGeneration, \"research linked job generation\")\n\t\t\t\t\t\t!== integer(job.currentGeneration, \"research linked current generation\")\n\t\t\t\t) throw conflict(`background job ${jobId} is not current ${input.role} work for the turn`);\n\t\t\t\tlet current = input.role === \"evidence\"\n\t\t\t\t\t? foundTurn.evidenceJobId\n\t\t\t\t\t: foundTurn.answerJobId;\n\t\t\t\tif (current !== undefined) {\n\t\t\t\t\tif (current !== jobId) {\n\t\t\t\t\t\tthrow conflict(`research turn ${turnId} already has an ${input.role} job`);\n\t\t\t\t\t}\n\t\t\t\t\treturn { workspace: locked.workspace, turn: foundTurn, repeated: true };\n\t\t\t\t}\n\t\t\t\tlet [linked] = await transaction<{ id: string }[]>`\n\t\t\t\t\tSELECT id FROM research_turns\n\t\t\t\t\tWHERE evidence_job_id = ${jobId} OR answer_job_id = ${jobId}\n\t\t\t\t\tLIMIT 1\n\t\t\t\t`;\n\t\t\t\tif (linked) throw conflict(`background job ${jobId} is already linked to a research turn`);\n\t\t\t\tlet now = inputDate(input.now, \"job link time\");\n\t\t\t\tlet rows = input.role === \"evidence\"\n\t\t\t\t\t? await transaction`\n\t\t\t\t\t\tUPDATE research_turns SET\n\t\t\t\t\t\t\tevidence_job_id = ${jobId},\n\t\t\t\t\t\t\tupdated_at = GREATEST(updated_at, ${now})\n\t\t\t\t\t\tWHERE id = ${turnId} AND workspace_id = ${workspaceId}\n\t\t\t\t\t\tRETURNING ${transaction.unsafe(TURN_COLUMNS)}\n\t\t\t\t\t`\n\t\t\t\t\t: await transaction`\n\t\t\t\t\t\tUPDATE research_turns SET\n\t\t\t\t\t\t\tanswer_job_id = ${jobId},\n\t\t\t\t\t\t\tupdated_at = GREATEST(updated_at, ${now})\n\t\t\t\t\t\tWHERE id = ${turnId} AND workspace_id = ${workspaceId}\n\t\t\t\t\t\tRETURNING ${transaction.unsafe(TURN_COLUMNS)}\n\t\t\t\t\t`;\n\t\t\t\tlet savedTurnRow = rows[0];\n\t\t\t\tif (!savedTurnRow) throw corrupt(\"linking a research job returned no turn\");\n\t\t\t\tlet savedWorkspace = await this.#bumpWorkspace(transaction, workspaceId, now, 0, 0);\n\t\t\t\treturn {\n\t\t\t\t\tworkspace: savedWorkspace,\n\t\t\t\t\tturn: turn(savedTurnRow),\n\t\t\t\t\trepeated: false,\n\t\t\t\t};\n\t\t\t}));\n\n\treadonly resetInitialAttempt = (\n\t\tinput: ResetInitialResearchAttempt,\n\t): Promise =>\n\t\tthis.#run(\"reset initial research attempt\", () =>\n\t\t\tthis.#sql.begin(async transaction => {\n\t\t\t\tawait this.#fence(transaction, input.lease);\n\t\t\t\tlet channelId = required(input.channelId, \"channel id\");\n\t\t\t\tlet workspaceId = required(input.workspaceId, \"workspace id\");\n\t\t\t\tlet archived = await this.#lockChannelArchiveState(transaction, channelId);\n\t\t\t\tlet locked = await this.#lockWorkspace(transaction, channelId, workspaceId);\n\t\t\t\tif (archived) throw conflict(`channel ${channelId} is archived`);\n\t\t\t\tif (locked.workspace.publishedChannelId) {\n\t\t\t\t\tthrow conflict(`research workspace ${workspaceId} is already published`);\n\t\t\t\t}\n\t\t\t\tlet [foundTurnRow] = await transaction`\n\t\t\t\t\tSELECT ${transaction.unsafe(TURN_COLUMNS)}\n\t\t\t\t\tFROM research_turns\n\t\t\t\t\tWHERE workspace_id = ${workspaceId} AND ordinal = 1\n\t\t\t\t\tFOR UPDATE\n\t\t\t\t`;\n\t\t\t\tlet foundTurn = foundTurnRow ? turn(foundTurnRow) : undefined;\n\t\t\t\tif (!foundTurn || foundTurn.kind !== \"initial\") {\n\t\t\t\t\tthrow conflict(`research workspace ${workspaceId} has no initial turn`);\n\t\t\t\t}\n\t\t\t\tif (\n\t\t\t\t\tfoundTurn.evidenceJobId !== input.expectedEvidenceJobId\n\t\t\t\t\t|| foundTurn.answerJobId !== input.expectedAnswerJobId\n\t\t\t\t) throw conflict(`research workspace ${workspaceId} changed before retry`);\n\t\t\t\tif (!foundTurn.evidenceJobId && !foundTurn.answerJobId) {\n\t\t\t\t\treturn { workspace: locked.workspace, turn: foundTurn, repeated: true };\n\t\t\t\t}\n\t\t\t\tlet states: BackgroundJobState[] = [];\n\t\t\t\tfor (let jobId of [foundTurn.evidenceJobId, foundTurn.answerJobId]) {\n\t\t\t\t\tif (!jobId) continue;\n\t\t\t\t\tlet [job] = await transaction`\n\t\t\t\t\t\tSELECT id, state FROM background_jobs\n\t\t\t\t\t\tWHERE id = ${jobId} AND channel_id = ${channelId}\n\t\t\t\t\t\tFOR UPDATE\n\t\t\t\t\t`;\n\t\t\t\t\tif (!job) {\n\t\t\t\t\t\tthrow missing(`background job ${jobId} does not exist in channel ${channelId}`);\n\t\t\t\t\t}\n\t\t\t\t\tlet state = text(job.state, \"retry job state\");\n\t\t\t\t\tif (!isBackgroundJobState(state)) throw corrupt(\"background job has an invalid state\");\n\t\t\t\t\tstates.push(state);\n\t\t\t\t}\n\t\t\t\tlet disposition = researchAttemptDisposition(states);\n\t\t\t\tif (disposition === \"active\") {\n\t\t\t\t\tthrow conflict(`research workspace ${workspaceId} still has active initial work`);\n\t\t\t\t}\n\t\t\t\tif (disposition !== \"retryable\") {\n\t\t\t\t\tthrow conflict(`research workspace ${workspaceId} has no terminal initial work`);\n\t\t\t\t}\n\t\t\t\tlet now = inputDate(input.now, \"retry time\");\n\t\t\t\tlet [savedTurnRow] = await transaction`\n\t\t\t\t\tUPDATE research_turns SET\n\t\t\t\t\t\tevidence_job_id = NULL,\n\t\t\t\t\t\tanswer_job_id = NULL,\n\t\t\t\t\t\tupdated_at = GREATEST(updated_at, ${now})\n\t\t\t\t\tWHERE id = ${foundTurn.id} AND workspace_id = ${workspaceId}\n\t\t\t\t\tRETURNING ${transaction.unsafe(TURN_COLUMNS)}\n\t\t\t\t`;\n\t\t\t\tif (!savedTurnRow) throw corrupt(\"resetting research work returned no turn\");\n\t\t\t\tlet savedWorkspace = await this.#bumpWorkspace(transaction, workspaceId, now, 0, 0);\n\t\t\t\treturn {\n\t\t\t\t\tworkspace: savedWorkspace,\n\t\t\t\t\tturn: turn(savedTurnRow),\n\t\t\t\t\trepeated: false,\n\t\t\t\t};\n\t\t\t}));\n\n\treadonly appendAgentMessage = (\n\t\tinput: AppendResearchAgentMessage,\n\t): Promise =>\n\t\tthis.#run(\"append research agent message\", () =>\n\t\t\tthis.#sql.begin(async transaction => {\n\t\t\t\tawait this.#fence(transaction, input.lease);\n\t\t\t\tlet channelId = required(input.channelId, \"channel id\");\n\t\t\t\tlet workspaceId = required(input.workspaceId, \"workspace id\");\n\t\t\t\tlet id = required(input.id, \"message id\");\n\t\t\t\tlet turnId = required(input.turnId, \"message turn id\");\n\t\t\t\tlet sourceJobId = required(input.sourceJobId, \"message source job id\");\n\t\t\t\tlet body = required(input.text, \"message text\");\n\t\t\t\tlet userId = optionalInput(input.userId, \"message user id\");\n\t\t\t\tlet userHandle = optionalInput(input.userHandle, \"message user handle\");\n\t\t\t\tlet locked = await this.#lockWorkspace(transaction, channelId, workspaceId);\n\t\t\t\tlet [existing] = await transaction`\n\t\t\t\t\tSELECT ${transaction.unsafe(MESSAGE_COLUMNS)}\n\t\t\t\t\tFROM research_messages\n\t\t\t\t\tWHERE id = ${id} OR (author_kind = 'agent' AND source_job_id = ${sourceJobId})\n\t\t\t\t\tORDER BY CASE WHEN id = ${id} THEN 0 ELSE 1 END\n\t\t\t\t\tLIMIT 1\n\t\t\t\t`;\n\t\t\t\tif (existing) {\n\t\t\t\t\tlet repeated = message(existing);\n\t\t\t\t\tif (\n\t\t\t\t\t\trepeated.workspaceId !== workspaceId\n\t\t\t\t\t\t|| repeated.authorKind !== \"agent\"\n\t\t\t\t\t\t|| repeated.turnId !== turnId\n\t\t\t\t\t\t|| repeated.sourceJobId !== sourceJobId\n\t\t\t\t\t\t|| repeated.userId !== userId\n\t\t\t\t\t\t|| repeated.userHandle !== userHandle\n\t\t\t\t\t\t|| repeated.text !== body\n\t\t\t\t\t) throw conflict(`research message ${id} was reused with another payload`);\n\t\t\t\t\treturn { workspace: locked.workspace, message: repeated, repeated: true };\n\t\t\t\t}\n\t\t\t\tlet foundTurn = await this.#lockTurn(transaction, workspaceId, turnId);\n\t\t\t\tif (foundTurn.answerJobId !== sourceJobId) {\n\t\t\t\t\tthrow conflict(`research turn ${turnId} is not linked to answer job ${sourceJobId}`);\n\t\t\t\t}\n\t\t\t\tlet [job] = await transaction<{ id: string }[]>`\n\t\t\t\t\tSELECT id FROM background_jobs\n\t\t\t\t\tWHERE id = ${sourceJobId} AND channel_id = ${channelId}\n\t\t\t\t`;\n\t\t\t\tif (!job) {\n\t\t\t\t\tthrow missing(`background job ${sourceJobId} does not exist in channel ${channelId}`);\n\t\t\t\t}\n\t\t\t\tlet now = inputDate(input.now, \"message creation time\");\n\t\t\t\tlet [saved] = await transaction`\n\t\t\t\t\tINSERT INTO research_messages (\n\t\t\t\t\t\tid, workspace_id, sequence, turn_id, author_kind, user_id,\n\t\t\t\t\t\tuser_handle, text, source_job_id, created_at\n\t\t\t\t\t) VALUES (\n\t\t\t\t\t\t${id}, ${workspaceId}, ${locked.nextMessageSequence}, ${turnId}, 'agent',\n\t\t\t\t\t\t${userId ?? null}, ${userHandle ?? null}, ${body}, ${sourceJobId}, ${now}\n\t\t\t\t\t)\n\t\t\t\t\tRETURNING ${transaction.unsafe(MESSAGE_COLUMNS)}\n\t\t\t\t`;\n\t\t\t\tif (!saved) throw corrupt(\"appending a research agent message returned no record\");\n\t\t\t\tlet savedWorkspace = await this.#bumpWorkspace(transaction, workspaceId, now, 0, 1);\n\t\t\t\treturn {\n\t\t\t\t\tworkspace: savedWorkspace,\n\t\t\t\t\tmessage: message(saved),\n\t\t\t\t\trepeated: false,\n\t\t\t\t};\n\t\t\t}));\n\n\treadonly publishInitialReport = (\n\t\tinput: PublishInitialResearchReport,\n\t): Promise =>\n\t\tthis.#run(\"publish initial research report\", () =>\n\t\t\tthis.#sql.begin(async transaction => {\n\t\t\t\tawait this.#fence(transaction, input.lease);\n\t\t\t\tlet channelId = required(input.channelId, \"channel id\");\n\t\t\t\tlet workspaceId = required(input.workspaceId, \"workspace id\");\n\t\t\t\tlet answerJobId = required(input.answerJobId, \"publication answer job id\");\n\t\t\t\tlet title = required(input.title, \"publication title\");\n\t\t\t\tlet now = inputDate(input.now, \"publication time\");\n\t\t\t\tlet [parentRow] = await transaction`\n\t\t\t\t\tSELECT\n\t\t\t\t\t\tid,\n\t\t\t\t\t\trepository_id AS \"repositoryId\",\n\t\t\t\t\t\trepository_owner AS \"repositoryOwner\",\n\t\t\t\t\t\trepository_name AS \"repositoryName\",\n\t\t\t\t\t\tparent_channel_id AS \"parentChannelId\",\n\t\t\t\t\t\tarchived_at AS \"archivedAt\"\n\t\t\t\t\tFROM channels\n\t\t\t\t\tWHERE id = ${channelId}\n\t\t\t\t\tFOR UPDATE\n\t\t\t\t`;\n\t\t\t\tif (!parentRow) throw missing(`channel ${channelId} does not exist`);\n\t\t\t\tlet parentId = text(parentRow.id, \"publication parent channel id\");\n\t\t\t\tlet repositoryId = text(parentRow.repositoryId, \"publication repository id\");\n\t\t\t\tlet locked = await this.#lockWorkspace(transaction, channelId, workspaceId);\n\t\t\t\tlet [initialTurnRow] = await transaction`\n\t\t\t\t\tSELECT ${transaction.unsafe(TURN_COLUMNS)}\n\t\t\t\t\tFROM research_turns\n\t\t\t\t\tWHERE workspace_id = ${workspaceId} AND ordinal = 1\n\t\t\t\t\tFOR UPDATE\n\t\t\t\t`;\n\t\t\t\tlet initialTurn = initialTurnRow ? turn(initialTurnRow) : undefined;\n\t\t\t\tif (\n\t\t\t\t\t!initialTurn\n\t\t\t\t\t|| initialTurn.kind !== \"initial\"\n\t\t\t\t\t|| initialTurn.answerJobId !== answerJobId\n\t\t\t\t) {\n\t\t\t\t\tthrow conflict(\n\t\t\t\t\t\t`research workspace ${workspaceId} is not linked to initial answer job ${answerJobId}`,\n\t\t\t\t\t);\n\t\t\t\t}\n\t\t\t\tif (locked.workspace.publishedChannelId) {\n\t\t\t\t\tlet [publishedRow] = await transaction`\n\t\t\t\t\t\tSELECT ${transaction.unsafe(PUBLICATION_CHANNEL_COLUMNS)}\n\t\t\t\t\t\tFROM channels\n\t\t\t\t\t\tWHERE channels.id = ${locked.workspace.publishedChannelId}\n\t\t\t\t\t`;\n\t\t\t\t\tif (!publishedRow) {\n\t\t\t\t\t\tthrow corrupt(\n\t\t\t\t\t\t\t`research workspace ${workspaceId} has a missing published channel`,\n\t\t\t\t\t\t);\n\t\t\t\t\t}\n\t\t\t\t\treturn {\n\t\t\t\t\t\tworkspace: locked.workspace,\n\t\t\t\t\t\tchannel: publicationChannel(publishedRow),\n\t\t\t\t\t\trepeated: true,\n\t\t\t\t\t};\n\t\t\t\t}\n\t\t\t\tif (parentRow.archivedAt !== null) throw conflict(`channel ${channelId} is archived`);\n\t\t\t\tif (parentRow.parentChannelId !== null) {\n\t\t\t\t\tthrow conflict(`channel ${channelId} cannot parent another child`);\n\t\t\t\t}\n\t\t\t\tlet [answer] = await transaction`\n\t\t\t\t\tSELECT\n\t\t\t\t\t\tjobs.id,\n\t\t\t\t\t\tjobs.type,\n\t\t\t\t\t\tjobs.target_key AS \"targetKey\",\n\t\t\t\t\t\tjobs.target_generation AS \"targetGeneration\",\n\t\t\t\t\t\ttargets.generation AS \"currentGeneration\",\n\t\t\t\t\t\tjobs.state,\n\t\t\t\t\t\tartifacts.job_id AS \"artifactJobId\"\n\t\t\t\t\tFROM background_jobs AS jobs\n\t\t\t\t\tJOIN background_job_targets AS targets\n\t\t\t\t\t\tON targets.channel_id = jobs.channel_id\n\t\t\t\t\t\tAND targets.target_key = jobs.target_key\n\t\t\t\t\tLEFT JOIN background_job_artifacts AS artifacts ON artifacts.job_id = jobs.id\n\t\t\t\t\tWHERE jobs.id = ${answerJobId} AND jobs.channel_id = ${channelId}\n\t\t\t\t\tFOR UPDATE OF jobs\n\t\t\t\t`;\n\t\t\t\tlet target = `research-answer:workspace:${workspaceId}:turn:${initialTurn.id}:answer`;\n\t\t\t\tif (\n\t\t\t\t\t!answer\n\t\t\t\t\t|| text(answer.type, \"publication answer job type\") !== \"research-answer\"\n\t\t\t\t\t|| text(answer.targetKey, \"publication answer job target\") !== target\n\t\t\t\t\t|| integer(answer.targetGeneration, \"publication answer job generation\")\n\t\t\t\t\t\t!== integer(answer.currentGeneration, \"publication current job generation\")\n\t\t\t\t\t|| text(answer.state, \"publication answer job state\") !== \"completed\"\n\t\t\t\t\t|| optionalText(answer.artifactJobId, \"publication answer artifact\") !== answerJobId\n\t\t\t\t) {\n\t\t\t\t\tthrow conflict(`background job ${answerJobId} is not current completed answer work`);\n\t\t\t\t}\n\n\t\t\t\tlet childId = deterministicChannelId(repositoryId, workspaceId);\n\t\t\t\tlet savedChannel = await this.#createChannel(\n\t\t\t\t\ttransaction,\n\t\t\t\t\t{\n\t\t\t\t\t\tid: childId,\n\t\t\t\t\t\trepositoryId,\n\t\t\t\t\t\trepositoryOwner: text(\n\t\t\t\t\t\t\tparentRow.repositoryOwner,\n\t\t\t\t\t\t\t\"publication repository owner\",\n\t\t\t\t\t\t),\n\t\t\t\t\t\trepositoryName: text(\n\t\t\t\t\t\t\tparentRow.repositoryName,\n\t\t\t\t\t\t\t\"publication repository name\",\n\t\t\t\t\t\t),\n\t\t\t\t\t\tparentChannelId: parentId,\n\t\t\t\t\t\ttitle,\n\t\t\t\t\t\tcreatedBy: locked.workspace.createdBy,\n\t\t\t\t\t\tnow,\n\t\t\t\t\t\tinitial: input.initial,\n\t\t\t\t\t},\n\t\t\t\t);\n\t\t\t\tlet [savedWorkspaceRow] = await transaction`\n\t\t\t\t\tUPDATE research_workspaces SET\n\t\t\t\t\t\tpublished_channel_id = ${childId},\n\t\t\t\t\t\trevision = revision + 1,\n\t\t\t\t\t\tupdated_at = GREATEST(updated_at, ${now})\n\t\t\t\t\tWHERE id = ${workspaceId} AND channel_id = ${channelId}\n\t\t\t\t\tRETURNING ${transaction.unsafe(WORKSPACE_COLUMNS)}\n\t\t\t\t`;\n\t\t\t\tif (!savedWorkspaceRow) {\n\t\t\t\t\tthrow corrupt(\"publishing an initial research report returned no workspace\");\n\t\t\t\t}\n\t\t\t\treturn {\n\t\t\t\t\tworkspace: workspace(savedWorkspaceRow),\n\t\t\t\t\tchannel: savedChannel,\n\t\t\t\t\trepeated: false,\n\t\t\t\t};\n\t\t\t}));\n\n\treadonly list = (\n\t\tchannelId: string,\n\t\tlimit: number,\n\t\tincludePlanner = true,\n\t): Promise =>\n\t\tthis.#run(\"list research workspaces\", async () => {\n\t\t\tlet count = Math.min(100, Math.max(1, limit));\n\t\t\tlet rows = await this.#sql`\n\t\t\t\tSELECT ${this.#sql.unsafe(WORKSPACE_COLUMNS)}\n\t\t\t\tFROM research_workspaces\n\t\t\t\tWHERE channel_id = ${channelId}\n\t\t\t\t\tAND (${includePlanner} OR origin <> 'planner')\n\t\t\t\tORDER BY updated_at DESC, id ASC\n\t\t\t\tLIMIT ${count}\n\t\t\t`;\n\t\t\treturn rows.map(workspace);\n\t\t});\n\n\treadonly listRepository = (\n\t\trepositoryId: string,\n\t\tlimit: number,\n\t\tincludeArchived = false,\n\t\tincludePlanner = true,\n\t): Promise =>\n\t\tthis.#run(\n\t\t\t\"list repository research workspaces\",\n\t\t\t() =>\n\t\t\t\tthis.#sql.begin(\"isolation level repeatable read read only\", async transaction => {\n\t\t\t\t\tlet count = Math.min(RESEARCH_REPOSITORY_WORKSPACE_LIMIT, Math.max(1, limit));\n\t\t\t\t\tlet channelRows = await transaction`\n\t\t\t\t\t\tSELECT\n\t\t\t\t\t\t\tchannels.id,\n\t\t\t\t\t\t\tchannels.repository_id AS \"repositoryId\",\n\t\t\t\t\t\t\tchannels.repository_owner AS \"repositoryOwner\",\n\t\t\t\t\t\t\tchannels.repository_name AS \"repositoryName\",\n\t\t\t\t\t\t\tchannels.title,\n\t\t\t\t\t\t\t(\n\t\t\t\t\t\t\t\tSELECT channel_slugs.slug\n\t\t\t\t\t\t\t\tFROM channel_slugs\n\t\t\t\t\t\t\t\tWHERE channel_slugs.channel_id = channels.id AND channel_slugs.canonical\n\t\t\t\t\t\t\t) AS slug\n\t\t\t\t\t\tFROM channels\n\t\t\t\t\t\tWHERE channels.repository_id = ${repositoryId}\n\t\t\t\t\t\t\tAND (${includeArchived} OR channels.archived_at IS NULL)\n\t\t\t\t\t\tORDER BY channels.created_at DESC, channels.id ASC\n\t\t\t\t\t\tLIMIT ${RESEARCH_REPOSITORY_CHANNEL_LIMIT + 1}\n\t\t\t\t\t`;\n\t\t\t\t\tlet channels = channelRows.slice(0, RESEARCH_REPOSITORY_CHANNEL_LIMIT)\n\t\t\t\t\t\t.map(repositoryChannel);\n\t\t\t\t\tlet channelsById = new Map(channels.map(channel => [channel.id, channel]));\n\t\t\t\t\tlet workspaceRows = await transaction`\n\t\t\t\t\t\tWITH repository_channels AS MATERIALIZED (\n\t\t\t\t\t\t\tSELECT channels.id, channels.created_at\n\t\t\t\t\t\t\tFROM channels\n\t\t\t\t\t\t\tWHERE channels.repository_id = ${repositoryId}\n\t\t\t\t\t\t\t\tAND (${includeArchived} OR channels.archived_at IS NULL)\n\t\t\t\t\t\t\tORDER BY channels.created_at DESC, channels.id ASC\n\t\t\t\t\t\t\tLIMIT ${RESEARCH_REPOSITORY_CHANNEL_LIMIT}\n\t\t\t\t\t\t)\n\t\t\t\t\t\tSELECT workspaces.*\n\t\t\t\t\t\tFROM repository_channels\n\t\t\t\t\t\tCROSS JOIN LATERAL (\n\t\t\t\t\t\t\tSELECT ${transaction.unsafe(WORKSPACE_COLUMNS)}\n\t\t\t\t\t\t\tFROM research_workspaces\n\t\t\t\t\t\t\tWHERE research_workspaces.channel_id = repository_channels.id\n\t\t\t\t\t\t\t\tAND (${includePlanner} OR research_workspaces.origin <> 'planner')\n\t\t\t\t\t\t\tORDER BY research_workspaces.updated_at DESC, research_workspaces.id ASC\n\t\t\t\t\t\t\tLIMIT ${RESEARCH_REPOSITORY_CHANNEL_WORKSPACE_LIMIT}\n\t\t\t\t\t\t) AS workspaces\n\t\t\t\t\t\tORDER BY\n\t\t\t\t\t\t\trepository_channels.created_at DESC,\n\t\t\t\t\t\t\trepository_channels.id ASC,\n\t\t\t\t\t\t\tworkspaces.\"updatedAt\" DESC,\n\t\t\t\t\t\t\tworkspaces.id ASC\n\t\t\t\t\t\tLIMIT ${count}\n\t\t\t\t\t`;\n\t\t\t\t\tlet groups: ResearchWorkspaceRepositoryGroup[] = [];\n\t\t\t\t\tlet groupsByChannel = new Map();\n\t\t\t\t\tfor (let row of workspaceRows) {\n\t\t\t\t\t\tlet saved = workspace(row);\n\t\t\t\t\t\tlet channel = channelsById.get(saved.channelId);\n\t\t\t\t\t\tif (!channel) {\n\t\t\t\t\t\t\tthrow corrupt(`research workspace ${saved.id} has an invalid repository channel`);\n\t\t\t\t\t\t}\n\t\t\t\t\t\tlet group = groupsByChannel.get(channel.id);\n\t\t\t\t\t\tif (!group) {\n\t\t\t\t\t\t\tgroup = { channel, workspaces: [] };\n\t\t\t\t\t\t\tgroupsByChannel.set(channel.id, group);\n\t\t\t\t\t\t\tgroups.push(group);\n\t\t\t\t\t\t}\n\t\t\t\t\t\tgroup.workspaces.push(saved);\n\t\t\t\t\t}\n\t\t\t\t\tlet truncated = channelRows.length > RESEARCH_REPOSITORY_CHANNEL_LIMIT\n\t\t\t\t\t\t|| workspaceRows.length === count\n\t\t\t\t\t\t|| groups.some(group =>\n\t\t\t\t\t\t\tgroup.workspaces.length === RESEARCH_REPOSITORY_CHANNEL_WORKSPACE_LIMIT\n\t\t\t\t\t\t);\n\t\t\t\t\treturn { channels: groups, truncated };\n\t\t\t\t}),\n\t\t);\n\n\treadonly get = (\n\t\tchannelId: string,\n\t\tworkspaceId: string,\n\t): Promise =>\n\t\tthis.#run(\n\t\t\t\"read research workspace\",\n\t\t\t() =>\n\t\t\t\tthis.#sql.begin(\"isolation level repeatable read read only\", async transaction => {\n\t\t\t\t\tlet [workspaceRow] = await transaction`\n\t\t\t\t\t\tSELECT ${transaction.unsafe(LOCKED_WORKSPACE_COLUMNS)}\n\t\t\t\t\t\tFROM research_workspaces\n\t\t\t\t\t\tWHERE id = ${workspaceId} AND channel_id = ${channelId}\n\t\t\t\t\t`;\n\t\t\t\t\tif (!workspaceRow) return undefined;\n\t\t\t\t\tlet locked = lockedWorkspace(workspaceRow);\n\t\t\t\t\tlet savedWorkspace = locked.workspace;\n\t\t\t\t\tlet turnRows = await transaction`\n\t\t\t\t\t\tSELECT ${transaction.unsafe(TURN_COLUMNS)}\n\t\t\t\t\t\tFROM research_turns\n\t\t\t\t\t\tWHERE workspace_id = ${workspaceId}\n\t\t\t\t\t\tORDER BY ordinal ASC\n\t\t\t\t\t\tLIMIT 102\n\t\t\t\t\t`;\n\t\t\t\t\tlet messageRows = await transaction`\n\t\t\t\t\t\tSELECT ${transaction.unsafe(MESSAGE_COLUMNS)}\n\t\t\t\t\t\tFROM research_messages\n\t\t\t\t\t\tWHERE workspace_id = ${workspaceId}\n\t\t\t\t\t\tORDER BY sequence ASC\n\t\t\t\t\t\tLIMIT 202\n\t\t\t\t\t`;\n\t\t\t\t\tawait this.#validateJobChannels(transaction, savedWorkspace);\n\t\t\t\t\tlet detail = {\n\t\t\t\t\t\tworkspace: savedWorkspace,\n\t\t\t\t\t\tturns: turnRows.map(turn),\n\t\t\t\t\t\tmessages: messageRows.map(message),\n\t\t\t\t\t};\n\t\t\t\t\tthis.#validateDetail(detail, locked);\n\t\t\t\t\treturn detail;\n\t\t\t\t}),\n\t\t);\n\n\treadonly findByIdempotencyKey = (\n\t\tchannelId: string,\n\t\tidempotencyKey: string,\n\t): Promise =>\n\t\tthis.#run(\"find research workspace by request key\", async () => {\n\t\t\tlet [row] = await this.#sql<{ id: unknown }[]>`\n\t\t\t\tSELECT id FROM research_workspaces\n\t\t\t\tWHERE channel_id = ${channelId} AND idempotency_key = ${idempotencyKey}\n\t\t\t`;\n\t\t\treturn row ? this.get(channelId, text(row.id, \"research workspace id\")) : undefined;\n\t\t});\n\n\treadonly findPublished = (\n\t\tchannelId: string,\n\t\tpublishedChannelId: string,\n\t): Promise =>\n\t\tthis.#run(\"find published research workspace\", async () => {\n\t\t\tlet [row] = await this.#sql<{ id: unknown }[]>`\n\t\t\t\tSELECT id FROM research_workspaces\n\t\t\t\tWHERE channel_id = ${channelId} AND published_channel_id = ${publishedChannelId}\n\t\t\t`;\n\t\t\treturn row ? this.get(channelId, text(row.id, \"research workspace id\")) : undefined;\n\t\t});\n\n\treadonly findTurnByJob = (channelId: string, jobId: string): Promise =>\n\t\tthis.#run(\"find research turn by job\", async () => {\n\t\t\tlet rows = await this.#sql<\n\t\t\t\t(TurnRow & { workspaceChannelId: unknown; jobChannelId: unknown })[]\n\t\t\t>`\n\t\t\t\tSELECT ${this.#sql.unsafe(QUALIFIED_TURN_COLUMNS)},\n\t\t\t\t\tresearch_workspaces.channel_id AS \"workspaceChannelId\",\n\t\t\t\t\tbackground_jobs.channel_id AS \"jobChannelId\"\n\t\t\t\tFROM research_turns\n\t\t\t\tJOIN research_workspaces ON research_workspaces.id = research_turns.workspace_id\n\t\t\t\tJOIN background_jobs ON background_jobs.id = ${jobId}\n\t\t\t\tWHERE research_workspaces.channel_id = ${channelId}\n\t\t\t\t\tAND (research_turns.evidence_job_id = ${jobId} OR research_turns.answer_job_id = ${jobId})\n\t\t\t\tLIMIT 2\n\t\t\t`;\n\t\t\tif (rows.length > 1) {\n\t\t\t\tthrow corrupt(`background job ${jobId} links to multiple research turns`);\n\t\t\t}\n\t\t\tlet row = rows[0];\n\t\t\tif (!row) return undefined;\n\t\t\tlet workspaceChannelId = text(row.workspaceChannelId, \"research workspace channel id\");\n\t\t\tlet jobChannelId = text(row.jobChannelId, \"research linked job channel id\");\n\t\t\tif (workspaceChannelId !== jobChannelId || workspaceChannelId !== channelId) {\n\t\t\t\tthrow corrupt(`background job ${jobId} is linked across research channels`);\n\t\t\t}\n\t\t\treturn turn(row);\n\t\t});\n\n\tasync #lockWorkspace(\n\t\ttransaction: TransactionSQL,\n\t\tchannelId: string,\n\t\tworkspaceId: string,\n\t): Promise {\n\t\tlet [row] = await transaction`\n\t\t\tSELECT ${transaction.unsafe(LOCKED_WORKSPACE_COLUMNS)}\n\t\t\tFROM research_workspaces\n\t\t\tWHERE id = ${workspaceId} AND channel_id = ${channelId}\n\t\t\tFOR UPDATE\n\t\t`;\n\t\tif (!row) {\n\t\t\tthrow missing(`research workspace ${workspaceId} does not exist in channel ${channelId}`);\n\t\t}\n\t\treturn lockedWorkspace(row);\n\t}\n\n\tasync #lockChannelArchiveState(\n\t\ttransaction: TransactionSQL,\n\t\tchannelId: string,\n\t): Promise {\n\t\tlet [row] = await transaction<{ archivedAt: Timestamp | null }[]>`\n\t\t\tSELECT archived_at AS \"archivedAt\"\n\t\t\tFROM channels\n\t\t\tWHERE id = ${channelId}\n\t\t\tFOR UPDATE\n\t\t`;\n\t\tif (!row) throw missing(`channel ${channelId} does not exist`);\n\t\treturn row.archivedAt !== null;\n\t}\n\n\tasync #lockTurn(\n\t\ttransaction: TransactionSQL,\n\t\tworkspaceId: string,\n\t\tturnId: string,\n\t): Promise {\n\t\tlet [row] = await transaction`\n\t\t\tSELECT ${transaction.unsafe(TURN_COLUMNS)}\n\t\t\tFROM research_turns\n\t\t\tWHERE id = ${turnId} AND workspace_id = ${workspaceId}\n\t\t\tFOR UPDATE\n\t\t`;\n\t\tif (!row) throw missing(`research turn ${turnId} does not exist in workspace ${workspaceId}`);\n\t\treturn turn(row);\n\t}\n\n\tasync #turnForRequest(\n\t\ttransaction: TransactionSQL,\n\t\tworkspaceId: string,\n\t\trequestId: string,\n\t): Promise {\n\t\tlet [row] = await transaction`\n\t\t\tSELECT ${transaction.unsafe(TURN_COLUMNS)}\n\t\t\tFROM research_turns\n\t\t\tWHERE workspace_id = ${workspaceId} AND request_id = ${requestId}\n\t\t`;\n\t\treturn row ? turn(row) : undefined;\n\t}\n\n\tasync #memberMessage(\n\t\ttransaction: TransactionSQL,\n\t\tvalue: ResearchTurn,\n\t): Promise {\n\t\tlet rows = await transaction`\n\t\t\tSELECT ${transaction.unsafe(MESSAGE_COLUMNS)}\n\t\t\tFROM research_messages\n\t\t\tWHERE workspace_id = ${value.workspaceId}\n\t\t\t\tAND turn_id = ${value.id}\n\t\t\t\tAND author_kind = 'member'\n\t\t\tLIMIT 2\n\t\t`;\n\t\tif (rows.length !== 1) throw corrupt(`research turn ${value.id} has invalid member messages`);\n\t\treturn message(rows[0]!);\n\t}\n\n\tasync #insertTurn(\n\t\ttransaction: TransactionSQL,\n\t\tinput: {\n\t\t\tid: string;\n\t\t\tworkspaceId: string;\n\t\t\tordinal: number;\n\t\t\tkind: ResearchTurnKind;\n\t\t\trequestId: string;\n\t\t\tfingerprint: string;\n\t\t\tquestion: string;\n\t\t\trequestedBy: string;\n\t\t\tnow: Date;\n\t\t},\n\t): Promise {\n\t\tlet [saved] = await transaction`\n\t\t\tINSERT INTO research_turns (\n\t\t\t\tid, workspace_id, ordinal, kind, request_id, fingerprint,\n\t\t\t\tquestion, requested_by, created_at, updated_at\n\t\t\t) VALUES (\n\t\t\t\t${input.id}, ${input.workspaceId}, ${input.ordinal}, ${input.kind},\n\t\t\t\t${input.requestId}, ${input.fingerprint}, ${input.question},\n\t\t\t\t${input.requestedBy}, ${input.now}, ${input.now}\n\t\t\t)\n\t\t\tRETURNING ${transaction.unsafe(TURN_COLUMNS)}\n\t\t`;\n\t\tif (!saved) throw corrupt(\"creating a research turn returned no record\");\n\t\treturn turn(saved);\n\t}\n\n\tasync #insertMemberMessage(\n\t\ttransaction: TransactionSQL,\n\t\tworkspaceId: string,\n\t\tsequence: number,\n\t\tid: string,\n\t\tvalue: ResearchTurn,\n\t\tuserHandle: string | undefined,\n\t\tnow: Date,\n\t): Promise {\n\t\tlet [saved] = await transaction`\n\t\t\tINSERT INTO research_messages (\n\t\t\t\tid, workspace_id, sequence, turn_id, author_kind, user_id,\n\t\t\t\tuser_handle, text, created_at\n\t\t\t) VALUES (\n\t\t\t\t${id}, ${workspaceId}, ${sequence}, ${value.id}, 'member', ${value.requestedBy},\n\t\t\t\t${userHandle ?? null}, ${value.question}, ${now}\n\t\t\t)\n\t\t\tRETURNING ${transaction.unsafe(MESSAGE_COLUMNS)}\n\t\t`;\n\t\tif (!saved) throw corrupt(\"creating a research member message returned no record\");\n\t\treturn message(saved);\n\t}\n\n\tasync #bumpWorkspace(\n\t\ttransaction: TransactionSQL,\n\t\tworkspaceId: string,\n\t\tnow: Date,\n\t\tturns: number,\n\t\tmessages: number,\n\t): Promise {\n\t\tlet [saved] = await transaction`\n\t\t\tUPDATE research_workspaces SET\n\t\t\t\trevision = revision + 1,\n\t\t\t\tnext_turn_ordinal = next_turn_ordinal + ${turns},\n\t\t\t\tnext_message_sequence = next_message_sequence + ${messages},\n\t\t\t\tupdated_at = GREATEST(updated_at, ${now})\n\t\t\tWHERE id = ${workspaceId}\n\t\t\tRETURNING ${transaction.unsafe(WORKSPACE_COLUMNS)}\n\t\t`;\n\t\tif (!saved) throw corrupt(\"advancing a research workspace returned no record\");\n\t\treturn workspace(saved);\n\t}\n\n\tasync #validateJobChannels(\n\t\ttransaction: TransactionSQL,\n\t\tvalue: ResearchWorkspace,\n\t): Promise {\n\t\tlet [invalid] = await transaction<{ count: Integer }[]>`\n\t\t\tSELECT count(*) AS count\n\t\t\tFROM (\n\t\t\t\tSELECT research_turns.id\n\t\t\t\tFROM research_turns\n\t\t\t\tLEFT JOIN background_jobs AS evidence\n\t\t\t\t\tON evidence.id = research_turns.evidence_job_id\n\t\t\t\tLEFT JOIN background_jobs AS answer\n\t\t\t\t\tON answer.id = research_turns.answer_job_id\n\t\t\t\tWHERE research_turns.workspace_id = ${value.id}\n\t\t\t\t\tAND (\n\t\t\t\t\t\t(research_turns.evidence_job_id IS NOT NULL AND evidence.channel_id <> ${value.channelId})\n\t\t\t\t\t\tOR\n\t\t\t\t\t\t(research_turns.answer_job_id IS NOT NULL AND answer.channel_id <> ${value.channelId})\n\t\t\t\t\t)\n\t\t\t\tUNION ALL\n\t\t\t\tSELECT research_messages.id\n\t\t\t\tFROM research_messages\n\t\t\t\tJOIN background_jobs ON background_jobs.id = research_messages.source_job_id\n\t\t\t\tWHERE research_messages.workspace_id = ${value.id}\n\t\t\t\t\tAND background_jobs.channel_id <> ${value.channelId}\n\t\t\t) AS invalid_links\n\t\t`;\n\t\tif (!invalid || integer(invalid.count, \"invalid research job link count\") !== 0) {\n\t\t\tthrow corrupt(`research workspace ${value.id} links jobs from another channel`);\n\t\t}\n\t}\n\n\t#validateDetail(value: ResearchWorkspaceDetail, locked: LockedWorkspace): void {\n\t\tlet { workspace: savedWorkspace, turns, messages } = value;\n\t\tif (\n\t\t\tlocked.nextTurnOrdinal !== turns.length + 1\n\t\t\t|| locked.nextMessageSequence !== messages.length + 1\n\t\t) throw corrupt(`research workspace ${savedWorkspace.id} has inconsistent next counters`);\n\t\tif (savedWorkspace.confirmedQuery === undefined) {\n\t\t\tif (turns.length > 0 || messages.length > 0) {\n\t\t\t\tthrow corrupt(`unconfirmed research workspace ${savedWorkspace.id} has a transcript`);\n\t\t\t}\n\t\t\treturn;\n\t\t}\n\t\tif (turns.length === 0 || turns[0]!.kind !== \"initial\") {\n\t\t\tthrow corrupt(`confirmed research workspace ${savedWorkspace.id} has no initial turn`);\n\t\t}\n\t\tif (\n\t\t\tturns[0]!.question !== savedWorkspace.confirmedQuery\n\t\t\t|| turns[0]!.requestedBy !== savedWorkspace.confirmedBy\n\t\t) throw corrupt(`research workspace ${savedWorkspace.id} has an inconsistent initial turn`);\n\t\tlet byId = new Map();\n\t\tfor (let [index, savedTurn] of turns.entries()) {\n\t\t\tif (savedTurn.workspaceId !== savedWorkspace.id || savedTurn.ordinal !== index + 1) {\n\t\t\t\tthrow corrupt(`research workspace ${savedWorkspace.id} has invalid turn ordering`);\n\t\t\t}\n\t\t\tif (index > 0 && savedTurn.kind === \"initial\") {\n\t\t\t\tthrow corrupt(`research workspace ${savedWorkspace.id} has multiple initial turns`);\n\t\t\t}\n\t\t\tbyId.set(savedTurn.id, savedTurn);\n\t\t}\n\t\tlet memberTurns = new Set();\n\t\tfor (let [index, savedMessage] of messages.entries()) {\n\t\t\tif (savedMessage.workspaceId !== savedWorkspace.id || savedMessage.sequence !== index + 1) {\n\t\t\t\tthrow corrupt(`research workspace ${savedWorkspace.id} has invalid message ordering`);\n\t\t\t}\n\t\t\tlet savedTurn = savedMessage.turnId ? byId.get(savedMessage.turnId) : undefined;\n\t\t\tif (savedMessage.turnId && !savedTurn) {\n\t\t\t\tthrow corrupt(`research message ${savedMessage.id} refers to another workspace`);\n\t\t\t}\n\t\t\tif (savedMessage.authorKind === \"member\") {\n\t\t\t\tif (\n\t\t\t\t\t!savedTurn\n\t\t\t\t\t|| memberTurns.has(savedTurn.id)\n\t\t\t\t\t|| savedMessage.userId !== savedTurn.requestedBy\n\t\t\t\t\t|| savedMessage.text !== savedTurn.question\n\t\t\t\t) throw corrupt(`research turn ${savedMessage.turnId} has an invalid member message`);\n\t\t\t\tmemberTurns.add(savedTurn.id);\n\t\t\t}\n\t\t\tif (\n\t\t\t\tsavedMessage.authorKind === \"agent\"\n\t\t\t\t&& (!savedTurn || savedTurn.answerJobId !== savedMessage.sourceJobId)\n\t\t\t) throw corrupt(`research agent message ${savedMessage.id} has an invalid answer job`);\n\t\t}\n\t\tif (memberTurns.size !== turns.length) {\n\t\t\tthrow corrupt(`research workspace ${savedWorkspace.id} is missing member messages`);\n\t\t}\n\t}\n}\n","editable",false,"branch","documentNavigation","repo","githubnext/chopin","repoId","7d1a8ac3-35b0-4dea-85d4-06a980f3bada","ownerId","org:89615882","site","nexthub","private","admin","settings","maintainer","triage","starred","stars",0,"watchers","watching","pinned","notify","views",[183,184,185,186,187,188,189,190,191,192,193,194,195],"navigation",{"_54":55,"_139":140,"_141":142,"_143":144,"_145":146,"_147":148,"_149":150},"sources",[],"viewer","meta",{"_131":132,"_133":134,"_135":136,"_42":31,"_137":126,"_138":31,"_48":49,"_50":49},"branches",[73,74,75,76,77,78,79,80,81,82,83,84,85,86,87,88,89,90,91,92,93,94,95,96,97,98,99,100,101,102,103,104,105,106,107,108,109,110,111,112,113,114,115,116,117,118,119,120,121,122,123,124,125,126,127,128,129,130],"tags",[69,70,71,72],"cloneUrl","https://git.nexthub.sh/githubnext/chopin.git","color-controls-slice-1","color-controls-slice-2","color-controls-slice-3","color-controls-slice-4","Krzysztof-Cieslak-patch-1","Krzysztof-Cieslak-patch-2","Maggie/app-preview-toolkit","Maggie/ci-playwright-install-timeout","Maggie/collaborative-visual-decision","Maggie/design-audit","Maggie/generic-visual-decision-runtime","Maggie/impeccable-chopin-metadata","Maggie/jev-chat-product","Maggie/jev-composed-assessment","Maggie/native-document-layouts","Maggie/openui-composition-product","Maggie/openui-composition-trial","Maggie/planner-visual-authoring","Maggie/planner-visual-requests","Maggie/visual-selection-eval","artifacts/pr-419-live-preview-20261009","automation/pr-maintenance-state","automation/use-effect/callout-disabled-picker-8cf9e49ba5c09471","automation/use-effect/collaboration-options-ref-4e3a5a08a879a5ae","automation/use-effect/room-workspace-effective-access-a57d40866c71bed0","chore/bun-1.4.2","color-controls","color-controls-plan","comments","design-pr-assets","design/archived-decisions-badge","design/channel-route-remount","design/chat-decision-entry","design/conversation-analysis-markers","design/decision-evidence","design/settled-line-icon","dev/integration","diagram-step-controls","feat/liveapp-frontend-pilot","feat/local-experiments","feat/local-launcher-tracer","fix/autolink-mdx-crash","github-pills/2-pills","github-pills/3-hover-card","maggie/app-preview-toolkit","maggie/ci-playwright-install-timeout","maggie/collaborative-visual-decision","maggie/design-audit","maggie/generic-visual-decision-runtime","maggie/impeccable-chopin-metadata","maggie/jev-composed-assessment","maggie/native-document-layouts","maggie/openui-composition-product","maggie/openui-composition-trial","maggie/planner-visual-authoring","maggie/planner-visual-requests","maggie/visual-selection-eval","main","plain-text-fence-chrome","tokens/09-copy","wireframes/2-renderer","wireframes/3-planner","description","Let's compose rich plans together","owner","githubnext","section","","head","empty","pins",[165,166,167],"documents",{"_160":161,"_162":163},"code",{"_156":157,"_158":159},"automations",{"_153":154,"_155":-5},"delivery",{"_151":49,"_152":-5},"tag","04zvKQ8QOrDUF8TO1Ovz0Zy8_TT","releases","applications","workflows",3,"deployments","commits",1000,"changes",13,"counts",{"_164":163},"total",11,"issue",{"_168":158,"_170":181,"_15":158,"_172":182,"_52":174,"_175":31,"_176":174,"_177":159},{"_168":178,"_170":179,"_15":178,"_172":180,"_52":174,"_175":31,"_176":174,"_177":49},{"_168":169,"_170":171,"_15":169,"_172":173,"_52":174,"_175":31,"_176":174,"_177":163},"id","issues","name","Issues","filters",{},true,"saved","pinnable","count","tasks","Tasks",{},"Changes",{},{"_168":158,"_170":181,"_15":158,"_172":226,"_52":174,"_175":31,"_176":174},{"_168":178,"_170":179,"_15":178,"_172":225,"_52":174,"_175":31,"_176":174},{"_168":169,"_170":171,"_15":169,"_172":224,"_52":174,"_175":31,"_176":174},{"_168":221,"_170":222,"_15":221,"_172":223,"_52":31,"_175":31,"_176":174},{"_168":218,"_170":219,"_15":218,"_172":220,"_52":31,"_175":31,"_176":174},{"_168":153,"_170":216,"_15":145,"_172":217,"_52":31,"_175":31,"_176":174},{"_168":155,"_170":213,"_15":214,"_172":215,"_52":31,"_175":31,"_176":174},{"_168":151,"_170":211,"_15":151,"_172":212,"_52":31,"_175":31,"_176":174},{"_168":207,"_170":208,"_15":209,"_172":210,"_52":31,"_175":31,"_176":174},{"_168":141,"_170":205,"_15":141,"_172":206,"_52":31,"_175":31,"_176":31},{"_168":202,"_170":203,"_15":202,"_172":204,"_52":31,"_175":31,"_176":31},{"_168":199,"_170":200,"_15":199,"_172":201,"_52":31,"_175":31,"_176":31},{"_168":196,"_170":197,"_15":196,"_172":198,"_52":31,"_175":31,"_176":31},"decisions","Decisions",{},"changelog","Changelog",{},"roadmap","Roadmap",{},"Documents",{},"activity","Activity","insights",{},"Releases",{},"Deployments","automations/deployments",{},"Workflows",{},"discussions","Discussions",{},"goals","Goals",{},{},{},{},"groups","user","agents",[],"now",1794441001595,"sidebar","expanded"]