[{"_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","e2e/research-offer-fixtures.ts","oid","097c6b1266adb8a2381534492c19298a539ad936","size",7795,"commit","2182c95de44a8f63fd86af1c5874ae0ca298f807","mounts",[],"source","plain",{"_13":14,"_15":16},"kind","text","import { createHash } from \"node:crypto\";\nimport { SQL } from \"bun\";\nimport {\n\tactOnResearchOffer,\n\tinitialState,\n\tofferResearch,\n} from \"../apps/server/src/conversation-plan/domain\";\n\nimport type { Chat, ConversationPlan } from \"../packages/protocol/index\";\n\nexport type OfferSpec = {\n\tid: string;\n\tbrief: string;\n\tstatus: \"accepted\" | \"offered\";\n\tworkspace?: \"unlinked\" | \"linked\";\n};\n\nfunction databaseUrl(): string {\n\treturn process.env.E2E_DATABASE_URL_0\n\t\t?? \"postgresql://chopin:chopin@127.0.0.1:5433/chopin?sslmode=disable\";\n}\n\nfunction digest(value: string): string {\n\treturn createHash(\"sha256\").update(value).digest(\"hex\");\n}\n\nexport function offerSources(specs: readonly OfferSpec[], handle: string) {\n\tlet state = initialState();\n\tlet transcript: Chat.Entry[] = [];\n\tfor (let [index, spec] of specs.entries()) {\n\t\tlet entry: Chat.Entry = {\n\t\t\tid: `source-${spec.id}`,\n\t\t\tauthor: { kind: \"member\", handle },\n\t\t\ttext: spec.brief,\n\t\t\tts: index + 1,\n\t\t};\n\t\ttranscript.push(entry);\n\t\tstate = offerResearch(state, {\n\t\t\tid: spec.id,\n\t\t\tneedId: `need-${spec.id}`,\n\t\t\tcontextId: \"context-v1\",\n\t\t\tbrief: entry.text,\n\t\t\tsource: {\n\t\t\t\tmessageId: entry.id,\n\t\t\t\tauthor: entry.author as Extract,\n\t\t\t\tquote: entry.text,\n\t\t\t\tstart: 0,\n\t\t\t\tend: entry.text.length,\n\t\t\t},\n\t\t}, entry);\n\t\tif (spec.status === \"accepted\") {\n\t\t\tstate = actOnResearchOffer(state, spec.id, {\n\t\t\t\tid: `action-${spec.id}`,\n\t\t\t\tkind: \"research\",\n\t\t\t\tactor: { kind: \"member\", handle },\n\t\t\t\tprincipalId: `U_${handle}`,\n\t\t\t\tat: index + 10,\n\t\t\t});\n\t\t}\n\t}\n\treturn { state, transcript };\n}\n\nexport async function saveConversationState(\n\tchannelId: string,\n\tstate: ConversationPlan.State,\n): Promise {\n\tlet database = new SQL(databaseUrl());\n\ttry {\n\t\tlet [row] = await database<{ sidecar: unknown }[]>`\n\t\t\tSELECT sidecar FROM channel_snapshots WHERE channel_id = ${channelId}\n\t\t`;\n\t\tif (!row) throw new Error(\"test channel snapshot was not seeded\");\n\t\tlet previous = typeof row.sidecar === \"string\"\n\t\t\t? JSON.parse(row.sidecar) as Record\n\t\t\t: row.sidecar as Record;\n\t\tlet sidecar = JSON.stringify({ ...previous, conversationPlan: state });\n\t\tawait database.begin(async transaction => {\n\t\t\tawait transaction`\n\t\t\t\tUPDATE channel_snapshots SET sidecar = ${sidecar}::jsonb\n\t\t\t\tWHERE channel_id = ${channelId}\n\t\t\t`;\n\t\t\tawait transaction`\n\t\t\t\tUPDATE channel_state SET sidecar = ${sidecar}::jsonb\n\t\t\t\tWHERE channel_id = ${channelId}\n\t\t\t`;\n\t\t});\n\t} finally {\n\t\tawait database.close();\n\t}\n}\n\nexport async function seedRequest(\n\tchannelId: string,\n\tspec: OfferSpec,\n\tstage: \"unlinked\" | \"linked\",\n\thandle = \"readonly\",\n): Promise {\n\tlet requestedBy = `U_${handle}`;\n\tlet originMessageId = `source-${spec.id}`;\n\tlet question = spec.brief;\n\tlet workspaceId = `workspace-${crypto.randomUUID()}`;\n\tlet turnId = crypto.randomUUID();\n\tlet messageId = crypto.randomUUID();\n\tlet jobId = stage === \"linked\" ? crypto.randomUUID() : undefined;\n\tlet targetKey = jobId ? `research-evidence:${turnId}` : undefined;\n\tlet now = new Date();\n\tlet idempotencyKey = `research-planner:${digest(originMessageId).slice(0, 48)}`;\n\tlet fingerprint = digest(`research-planner\\0${\n\t\tJSON.stringify({\n\t\t\tchannelId,\n\t\t\tquestion,\n\t\t\toriginMessageId,\n\t\t\trequestedBy,\n\t\t\trequestedByHandle: handle,\n\t\t})\n\t}`);\n\tlet database = new SQL(databaseUrl());\n\ttry {\n\t\tawait database.begin(async transaction => {\n\t\t\tif (jobId && targetKey) {\n\t\t\t\tawait transaction`\n\t\t\t\t\tINSERT INTO background_job_channels (channel_id, revision)\n\t\t\t\t\tVALUES (${channelId}, 1)\n\t\t\t\t`;\n\t\t\t\tawait transaction`\n\t\t\t\t\tINSERT INTO background_job_targets (channel_id, target_key, generation)\n\t\t\t\t\tVALUES (${channelId}, ${targetKey}, 1)\n\t\t\t\t`;\n\t\t\t\tawait transaction`\n\t\t\t\t\tINSERT INTO background_jobs (\n\t\t\t\t\t\tid, channel_id, type, version, origin, target_key, target_generation,\n\t\t\t\t\t\tidempotency_key, fingerprint, input, state, revision, attempts,\n\t\t\t\t\t\tclaim_generation, available_at, created_at, updated_at\n\t\t\t\t\t) VALUES (\n\t\t\t\t\t\t${jobId}, ${channelId}, 'research-evidence', 1, 'planner', ${targetKey}, 1,\n\t\t\t\t\t\t${`e2e-${jobId}`}, ${`fixture-${jobId}`},\n\t\t\t\t\t\t${JSON.stringify({ workspaceId, turnId, question })}::jsonb,\n\t\t\t\t\t\t'pending', 1, 0, 0, ${now}, ${now}, ${now}\n\t\t\t\t\t)\n\t\t\t\t`;\n\t\t\t}\n\t\t\tawait transaction`\n\t\t\t\tINSERT INTO research_workspaces (\n\t\t\t\t\tid, channel_id, title, proposed_question, confirmed_query, origin,\n\t\t\t\t\torigin_message_id, inline_reference, created_by, confirmed_by,\n\t\t\t\t\trevision, next_turn_ordinal, next_message_sequence,\n\t\t\t\t\tidempotency_key, fingerprint, created_at, updated_at\n\t\t\t\t) VALUES (\n\t\t\t\t\t${workspaceId}, ${channelId}, ${question}, ${question}, ${question}, 'planner',\n\t\t\t\t\t${originMessageId}, ${stage === \"linked\" ? \"placed\" : \"pending\"},\n\t\t\t\t\t${requestedBy}, ${requestedBy}, 0, 2, 2,\n\t\t\t\t\t${idempotencyKey}, ${fingerprint}, ${now}, ${now}\n\t\t\t\t)\n\t\t\t`;\n\t\t\tawait transaction`\n\t\t\t\tINSERT INTO research_turns (\n\t\t\t\t\tid, workspace_id, ordinal, kind, request_id, fingerprint, question,\n\t\t\t\t\trequested_by, evidence_job_id, created_at, updated_at\n\t\t\t\t) VALUES (\n\t\t\t\t\t${turnId}, ${workspaceId}, 1, 'initial', ${originMessageId}, ${fingerprint},\n\t\t\t\t\t${question}, ${requestedBy}, ${jobId ?? null}, ${now}, ${now}\n\t\t\t\t)\n\t\t\t`;\n\t\t\tawait transaction`\n\t\t\t\tINSERT INTO research_messages (\n\t\t\t\t\tid, workspace_id, sequence, turn_id, author_kind, user_id,\n\t\t\t\t\tuser_handle, text, created_at\n\t\t\t\t) VALUES (\n\t\t\t\t\t${messageId}, ${workspaceId}, 1, ${turnId}, 'member', ${requestedBy},\n\t\t\t\t\t${handle}, ${question}, ${now}\n\t\t\t\t)\n\t\t\t`;\n\t\t});\n\t} finally {\n\t\tawait database.close();\n\t}\n\treturn workspaceId;\n}\n\nexport async function transportState(channelIds: readonly string[]) {\n\tlet database = new SQL(databaseUrl());\n\ttry {\n\t\tlet snapshots = [];\n\t\tfor (let channelId of channelIds) {\n\t\t\tlet [plan] = await database<{ revision: number | null }[]>`\n\t\t\t\tSELECT (sidecar->'conversationPlan'->>'revision')::int AS revision\n\t\t\t\tFROM channel_snapshots WHERE channel_id = ${channelId}\n\t\t\t`;\n\t\t\tlet owners = await database<{ ownerSessionId: string | null; status: string }[]>`\n\t\t\t\tSELECT owner_session_id AS \"ownerSessionId\", status\n\t\t\t\tFROM agent_state WHERE channel_id = ${channelId}\n\t\t\t\tORDER BY generation\n\t\t\t`;\n\t\t\tlet jobs = await database<{ id: string; type: string; state: string; revision: number }[]>`\n\t\t\t\tSELECT id, type, state, revision FROM background_jobs\n\t\t\t\tWHERE channel_id = ${channelId} ORDER BY id\n\t\t\t`;\n\t\t\tlet workspaces = await database<{\n\t\t\t\tid: string;\n\t\t\t\tinlineReference: string | null;\n\t\t\t}[]>`\n\t\t\t\tSELECT id, inline_reference AS \"inlineReference\" FROM research_workspaces\n\t\t\t\tWHERE channel_id = ${channelId} ORDER BY id\n\t\t\t`;\n\t\t\tlet turns = await database<{\n\t\t\t\tid: string;\n\t\t\t\tevidenceJobId: string | null;\n\t\t\t}[]>`\n\t\t\t\tSELECT turns.id, turns.evidence_job_id AS \"evidenceJobId\"\n\t\t\t\tFROM research_turns AS turns\n\t\t\t\tJOIN research_workspaces AS workspaces ON workspaces.id = turns.workspace_id\n\t\t\t\tWHERE workspaces.channel_id = ${channelId} ORDER BY turns.id\n\t\t\t`;\n\t\t\tsnapshots.push({ channelId, plan, owners, jobs, workspaces, turns });\n\t\t}\n\t\treturn snapshots;\n\t} finally {\n\t\tawait database.close();\n\t}\n}\n\nexport async function researchWorkCounts(channelId: string): Promise<{\n\tjobs: number;\n\towners: number;\n\tworkspaces: number;\n}> {\n\tlet database = new SQL(databaseUrl());\n\ttry {\n\t\tlet [counts] = await database<{\n\t\t\tjobs: number;\n\t\t\towners: number;\n\t\t\tworkspaces: number;\n\t\t}[]>`\n\t\t\tSELECT\n\t\t\t\t(SELECT count(*)::int FROM background_jobs WHERE channel_id = ${channelId}) AS jobs,\n\t\t\t\t(SELECT count(*)::int FROM agent_state WHERE channel_id = ${channelId}) AS owners,\n\t\t\t\t(SELECT count(*)::int FROM research_workspaces WHERE channel_id = ${channelId}) AS workspaces\n\t\t`;\n\t\tif (!counts) throw new Error(\"could not read research work counts\");\n\t\treturn counts;\n\t} finally {\n\t\tawait database.close();\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",1794434521406,"sidebar","expanded"]