[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10,"_11":12},"actionData","errors","root",{"_229":-5,"_232":233,"_234":235},"routes/shell",{"_42":43,"_228":-5,"_229":-5,"_230":231},"routes/repo",{"_33":-7,"_34":35,"_36":37,"_38":39,"_40":41,"_42":43,"_44":31,"_45":31,"_46":31,"_47":31,"_48":31,"_49":31,"_50":51,"_52":51,"_53":31,"_54":-7,"_55":-7,"_56":57,"_58":59,"_60":61,"_62":-5,"_63":64,"_65":66,"_67":68,"_69":70},"routes/repo.blob",{"_13":14,"_15":16,"_17":18,"_19":20,"_21":14,"_22":23,"_24":-5,"_25":26,"_27":28,"_28":29,"_30":31,"_32":14},"ref","294e1abbd2e20effef33554d1a93b6eea22fd0cd","path","apps/web/src/chat/research-offer.tsx","oid","05b5ae0d11d7efb5dd7495e77cace68383fbb517","size",9440,"commit","mounts",[],"source","plain",{"_13":14,"_15":16},"kind","text","import { useCallback, useEffect, useRef, useState, useSyncExternalStore } from \"react\";\nimport { SearchIcon } from \"@chopin/icons\";\n\nimport type { ConversationPlan, Research } from \"@chopin/protocol\";\nimport type { ResearchRequestStore } from \"../research-requests\";\nimport type { Wire } from \"../wire\";\n\nconst RETRY_DELAYS = [2_000, 5_000, 10_000];\n\nexport type OfferLinkView = {\n\tstatus: \"checking\" | \"pending\" | \"unlinked\" | \"linked\" | \"error\";\n\tresearchRequestId?: string;\n\texhausted?: boolean;\n};\n\nexport type ResearchOfferControls = {\n\tlinks: Readonly>;\n\tbusy: ReadonlySet;\n\terrors: Readonly>;\n\tcanAct: boolean;\n\tstore: ResearchRequestStore;\n\tonAction: (offerId: string, choice: \"research\" | \"dismiss\" | \"resume\") => void;\n};\n\nexport function shouldShowResearchActionError(\n\tchoice: \"research\" | \"dismiss\" | \"resume\",\n\tofferStatus: ConversationPlan.ResearchOffer[\"status\"] | undefined,\n\tlinkStatus: OfferLinkView[\"status\"] | undefined,\n): boolean {\n\treturn choice === \"resume\"\n\t\t? offerStatus === \"accepted\" && linkStatus !== \"linked\"\n\t\t: offerStatus === \"offered\";\n}\n\ntype Tracker = {\n\tid: string;\n\tinFlight: boolean;\n\tdirty: boolean;\n\tretries: number;\n\tstatus: OfferLinkView[\"status\"];\n\ttimer?: ReturnType;\n};\n\n/** Read-only accepted-offer observer; the timer boundary is injected for controlled-clock tests. */\nexport class ResearchOfferLinkObserver {\n\t#trackers = new Map();\n\t#links: Record = {};\n\t#disposed = false;\n\tconstructor(\n\t\tprivate readonly ask: (offerId: string) => Promise,\n\t\tprivate readonly publish: (links: Readonly>) => void,\n\t\tprivate readonly schedule = (run: () => void, ms: number) => setTimeout(run, ms),\n\t\tprivate readonly cancel = (timer: ReturnType) => clearTimeout(timer),\n\t) {}\n\n\taccept(ids: ReadonlySet): void {\n\t\tif (this.#disposed) return;\n\t\tlet changed = false;\n\t\tfor (let [id, tracker] of this.#trackers) {\n\t\t\tif (ids.has(id)) continue;\n\t\t\tif (tracker.timer !== undefined) this.cancel(tracker.timer);\n\t\t\tthis.#trackers.delete(id);\n\t\t\tdelete this.#links[id];\n\t\t\tchanged = true;\n\t\t}\n\t\tfor (let id of ids) {\n\t\t\tif (this.#trackers.has(id)) continue;\n\t\t\tthis.#trackers.set(id, {\n\t\t\t\tid,\n\t\t\t\tinFlight: false,\n\t\t\t\tdirty: false,\n\t\t\t\tretries: 0,\n\t\t\t\tstatus: \"checking\",\n\t\t\t});\n\t\t\tthis.#links[id] = { status: \"checking\" };\n\t\t\tchanged = true;\n\t\t\tthis.#read(id);\n\t\t}\n\t\tif (changed) this.#publish();\n\t}\n\n\tchanged(): void {\n\t\tfor (let tracker of this.#trackers.values()) {\n\t\t\tif (tracker.status !== \"linked\") this.#read(tracker.id);\n\t\t}\n\t}\n\n\trefresh(id: string, restart = false): void {\n\t\tlet tracker = this.#trackers.get(id);\n\t\tif (!tracker) return;\n\t\tif (restart) tracker.retries = 0;\n\t\tthis.#read(id);\n\t}\n\n\tdispose(): void {\n\t\tthis.#disposed = true;\n\t\tfor (let tracker of this.#trackers.values()) {\n\t\t\tif (tracker.timer !== undefined) this.cancel(tracker.timer);\n\t\t}\n\t\tthis.#trackers.clear();\n\t}\n\n\t#publish(): void {\n\t\tthis.publish({ ...this.#links });\n\t}\n\n\t#read(id: string): void {\n\t\tlet tracker = this.#trackers.get(id);\n\t\tif (!tracker || this.#disposed || tracker.status === \"linked\") return;\n\t\tif (tracker.timer !== undefined) this.cancel(tracker.timer);\n\t\ttracker.timer = undefined;\n\t\tif (tracker.inFlight) {\n\t\t\ttracker.dirty = true;\n\t\t\treturn;\n\t\t}\n\t\ttracker.inFlight = true;\n\t\tvoid this.ask(id).then(result => {\n\t\t\tif (this.#trackers.get(id) !== tracker) return;\n\t\t\tif (\n\t\t\t\tresult.offerId !== id\n\t\t\t\t|| ![\"pending\", \"unlinked\", \"linked\"].includes(result.status)\n\t\t\t\t|| result.status === \"pending\" && result.researchRequestId !== undefined\n\t\t\t\t|| result.status !== \"pending\" && !result.researchRequestId\n\t\t\t) throw new Error(\"research link response did not match the offer\");\n\t\t\ttracker.status = result.status;\n\t\t\tthis.#links[id] = {\n\t\t\t\tstatus: result.status,\n\t\t\t\t...(result.researchRequestId\n\t\t\t\t\t? { researchRequestId: result.researchRequestId }\n\t\t\t\t\t: {}),\n\t\t\t};\n\t\t\tthis.#publish();\n\t\t}).catch(() => {\n\t\t\tif (this.#trackers.get(id) !== tracker) return;\n\t\t\ttracker.status = \"error\";\n\t\t\tthis.#links[id] = { status: \"error\" };\n\t\t\tthis.#publish();\n\t\t}).finally(() => {\n\t\t\tif (this.#trackers.get(id) !== tracker) return;\n\t\t\ttracker.inFlight = false;\n\t\t\tif (tracker.status === \"linked\") return;\n\t\t\tif (tracker.dirty) {\n\t\t\t\ttracker.dirty = false;\n\t\t\t\tthis.#read(id);\n\t\t\t\treturn;\n\t\t\t}\n\t\t\tif (tracker.retries < RETRY_DELAYS.length) {\n\t\t\t\tlet delay = RETRY_DELAYS[tracker.retries++]!;\n\t\t\t\ttracker.timer = this.schedule(() => this.#read(id), delay);\n\t\t\t} else {\n\t\t\t\tthis.#links[id] = { ...this.#links[id]!, exhausted: true };\n\t\t\t\tthis.#publish();\n\t\t\t}\n\t\t});\n\t}\n}\n\n/** Observe exact accepted-offer links without starting or resuming research. */\nexport function useResearchOfferLinks(\n\twire: Wire | undefined,\n\tconnected: boolean,\n\toffers: readonly ConversationPlan.ResearchOffer[],\n): {\n\tlinks: Readonly>;\n\trefresh: (offerId: string, restart?: boolean) => void;\n} {\n\tlet [links, setLinks] = useState>>({});\n\tlet observer = useRef(undefined);\n\tuseEffect(() => {\n\t\tif (!wire || !connected) {\n\t\t\tsetLinks({});\n\t\t\treturn;\n\t\t}\n\t\tlet current = new ResearchOfferLinkObserver(\n\t\t\tofferId =>\n\t\t\t\twire.ask(\n\t\t\t\t\t\"conversation-plan:research-link\",\n\t\t\t\t\t{ offerId },\n\t\t\t\t),\n\t\t\tsetLinks,\n\t\t);\n\t\tobserver.current = current;\n\t\tlet off = wire.on(\"research:changed\", () => current.changed());\n\t\treturn () => {\n\t\t\toff();\n\t\t\tcurrent.dispose();\n\t\t\tif (observer.current === current) observer.current = undefined;\n\t\t};\n\t}, [wire, connected]);\n\tuseEffect(() => {\n\t\tobserver.current?.accept(\n\t\t\tnew Set(\n\t\t\t\toffers.filter(offer => offer.status === \"accepted\")\n\t\t\t\t\t.map(offer => offer.id),\n\t\t\t),\n\t\t);\n\t}, [wire, connected, offers]);\n\tlet refresh = useCallback((offerId: string, restart = false) => {\n\t\tobserver.current?.refresh(offerId, restart);\n\t}, []);\n\treturn { links, refresh };\n}\n\nfunction LinkedResearch({ id, store }: { id: string; store: ResearchRequestStore }) {\n\tlet subscribe = useCallback((listener: () => void) => store.subscribe(listener), [store]);\n\tlet request = useSyncExternalStore(subscribe, () => store.get(id), () => undefined);\n\tuseEffect(() => store.retain(id), [id, store]);\n\tif (!request) return

Loading research…

;\n\treturn (\n\t\t

\n\t\t\t\n\t\t\t\t{request.stage === \"ready\"\n\t\t\t\t\t? \"Research ready\"\n\t\t\t\t\t: `Research ${request.stage}`}\n\t\t\t\n\t\t\t{request.stage === \"ready\" && request.child && (\n\t\t\t\t store.open(request.child!, store.opener(id, event.currentTarget))}\n\t\t\t\t\ttype=\"button\"\n\t\t\t\t>\n\t\t\t\t\tOpen research\n\t\t\t\t\n\t\t\t)}\n\t\t

\n\t);\n}\n\nexport function ResearchOfferCard(\n\t{ offer, controls }: { offer: ConversationPlan.ResearchOffer; controls: ResearchOfferControls },\n) {\n\tlet busy = controls.busy.has(offer.id);\n\tlet link = controls.links[offer.id];\n\tlet canResume = link?.status === \"pending\" || link?.status === \"unlinked\";\n\treturn (\n\t\t\n\t\t\t

\n\t\t\t\t\n\t\t\t\t

\n\t\t\t\t\t{offer.brief}\n\t\t\t\t

\n\t\t\t

\n\t\t\t{offer.status === \"offered\" && controls.canAct && (\n\t\t\t\t

\n\t\t\t\t\t controls.onAction(offer.id, \"dismiss\")}\n\t\t\t\t\t\ttype=\"button\"\n\t\t\t\t\t>\n\t\t\t\t\t\tDismiss\n\t\t\t\t\t\n\t\t\t\t\t controls.onAction(offer.id, \"research\")}\n\t\t\t\t\t\ttype=\"button\"\n\t\t\t\t\t>\n\t\t\t\t\t\tResearch\n\t\t\t\t\t\n\t\t\t\t

\n\t\t\t)}\n\t\t\t{offer.status === \"dismissed\" &&

Dismissed

}\n\t\t\t{offer.status === \"accepted\" && link?.status === \"linked\" && link.researchRequestId\n\t\t\t\t? \n\t\t\t\t: offer.status === \"accepted\" && (\n\t\t\t\t\t

\n\t\t\t\t\t\t\n\t\t\t\t\t\t\t{link?.exhausted || link?.status === \"error\"\n\t\t\t\t\t\t\t\t? \"Accepted; request link not yet verified\"\n\t\t\t\t\t\t\t\t: link?.status === \"unlinked\"\n\t\t\t\t\t\t\t\t? \"Accepted; waiting to start\"\n\t\t\t\t\t\t\t\t: \"Research accepted\"}\n\t\t\t\t\t\t\n\t\t\t\t\t\t{controls.canAct && canResume && (\n\t\t\t\t\t\t\t controls.onAction(offer.id, \"resume\")}\n\t\t\t\t\t\t\t\ttype=\"button\"\n\t\t\t\t\t\t\t>\n\t\t\t\t\t\t\t\tResume\n\t\t\t\t\t\t\t\n\t\t\t\t\t\t)}\n\t\t\t\t\t

\n\t\t\t\t)}\n\t\t\t{busy &&

Saving…

}\n\t\t\t{link?.status !== \"linked\" && controls.errors[offer.id] && (\n\t\t\t\t

\n\t\t\t\t\t{controls.errors[offer.id]}\n\t\t\t\t

\n\t\t\t)}\n\t\t\n\t);\n}\n","editable",false,"branch","documentNavigation","repo","githubnext/chopin","repoId","7d1a8ac3-35b0-4dea-85d4-06a980f3bada","ownerId","org:89615882","organization",true,"site","nexthub","private","admin","settings","maintainer","triage","starred","stars",0,"watchers","watching","pinned","notify","views",[184,185,186,187,188,189,190,191,192,193,194,195,196],"navigation",{"_56":57,"_141":142,"_143":144,"_145":146,"_147":148,"_149":150,"_151":152},"sources",[],"viewer","meta",{"_133":134,"_135":136,"_137":138,"_44":31,"_139":128,"_140":31,"_50":51,"_52":51},"branches",[75,76,77,78,79,80,81,82,83,84,85,86,87,88,89,90,91,92,93,94,95,96,97,98,99,100,101,102,103,104,105,106,107,108,109,110,111,112,113,114,115,116,117,118,119,120,121,122,123,124,125,126,127,128,129,130,131,132],"tags",[71,72,73,74],"cloneUrl","https://git.nexthub.sh/githubnext/chopin.git","color-controls-slice-1","color-controls-slice-2","color-controls-slice-3","color-controls-slice-4","Krzysztof-Cieslak-patch-1","Krzysztof-Cieslak-patch-2","Maggie/app-preview-toolkit","Maggie/ci-playwright-install-timeout","Maggie/collaborative-visual-decision","Maggie/design-audit","Maggie/generic-visual-decision-runtime","Maggie/impeccable-chopin-metadata","Maggie/jev-chat-product","Maggie/jev-composed-assessment","Maggie/native-document-layouts","Maggie/openui-composition-product","Maggie/openui-composition-trial","Maggie/planner-visual-authoring","Maggie/planner-visual-requests","Maggie/visual-selection-eval","artifacts/pr-419-live-preview-20261009","automation/pr-maintenance-state","automation/use-effect/callout-disabled-picker-8cf9e49ba5c09471","automation/use-effect/collaboration-options-ref-4e3a5a08a879a5ae","automation/use-effect/room-workspace-effective-access-a57d40866c71bed0","chore/bun-1.4.2","color-controls","color-controls-plan","comments","design-pr-assets","design/archived-decisions-badge","design/channel-route-remount","design/chat-decision-entry","design/conversation-analysis-markers","design/decision-evidence","design/settled-line-icon","dev/integration","diagram-step-controls","feat/liveapp-frontend-pilot","feat/local-experiments","feat/local-launcher-tracer","fix/autolink-mdx-crash","github-pills/2-pills","github-pills/3-hover-card","maggie/app-preview-toolkit","maggie/ci-playwright-install-timeout","maggie/collaborative-visual-decision","maggie/design-audit","maggie/generic-visual-decision-runtime","maggie/impeccable-chopin-metadata","maggie/jev-composed-assessment","maggie/native-document-layouts","maggie/openui-composition-product","maggie/openui-composition-trial","maggie/planner-visual-authoring","maggie/planner-visual-requests","maggie/visual-selection-eval","main","plain-text-fence-chrome","tokens/09-copy","wireframes/2-renderer","wireframes/3-planner","description","Let's compose rich plans together","owner","githubnext","section","","head","empty","pins",[167,168,169],"documents",{"_162":163,"_164":165},"code",{"_158":159,"_160":161},"automations",{"_155":156,"_157":-5},"delivery",{"_153":51,"_154":-5},"tag","04zvKQ8QOrDUF8TO1Ovz0Zy8_TT","releases","applications","workflows",3,"deployments","commits",1000,"changes",13,"counts",{"_166":165},"total",11,"issue",{"_170":160,"_172":182,"_15":160,"_174":183,"_54":41,"_176":31,"_177":41,"_178":161},{"_170":179,"_172":180,"_15":179,"_174":181,"_54":41,"_176":31,"_177":41,"_178":51},{"_170":171,"_172":173,"_15":171,"_174":175,"_54":41,"_176":31,"_177":41,"_178":165},"id","issues","name","Issues","filters",{},"saved","pinnable","count","tasks","Tasks",{},"Changes",{},{"_170":160,"_172":182,"_15":160,"_174":227,"_54":41,"_176":31,"_177":41},{"_170":179,"_172":180,"_15":179,"_174":226,"_54":41,"_176":31,"_177":41},{"_170":171,"_172":173,"_15":171,"_174":225,"_54":41,"_176":31,"_177":41},{"_170":222,"_172":223,"_15":222,"_174":224,"_54":31,"_176":31,"_177":41},{"_170":219,"_172":220,"_15":219,"_174":221,"_54":31,"_176":31,"_177":41},{"_170":155,"_172":217,"_15":147,"_174":218,"_54":31,"_176":31,"_177":41},{"_170":157,"_172":214,"_15":215,"_174":216,"_54":31,"_176":31,"_177":41},{"_170":153,"_172":212,"_15":153,"_174":213,"_54":31,"_176":31,"_177":41},{"_170":208,"_172":209,"_15":210,"_174":211,"_54":31,"_176":31,"_177":41},{"_170":143,"_172":206,"_15":143,"_174":207,"_54":31,"_176":31,"_177":31},{"_170":203,"_172":204,"_15":203,"_174":205,"_54":31,"_176":31,"_177":31},{"_170":200,"_172":201,"_15":200,"_174":202,"_54":31,"_176":31,"_177":31},{"_170":197,"_172":198,"_15":197,"_174":199,"_54":31,"_176":31,"_177":31},"decisions","Decisions",{},"changelog","Changelog",{},"roadmap","Roadmap",{},"Documents",{},"activity","Activity","insights",{},"Releases",{},"Deployments","automations/deployments",{},"Workflows",{},"discussions","Discussions",{},"goals","Goals",{},{},{},{},"groups","user","agents",[],"now",1794675144503,"sidebar","expanded"]