[{"_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","18fa2804e8a256fee49b0aeb5bc2e6dae932c47d","path","apps/web/src/chat/research-offer.tsx","oid","39ef2f71162bf4760cd77812258f5f7498214582","size",9953,"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\tcanCheckLink: boolean;\n\tstore: ResearchRequestStore;\n\tonAction: (offerId: string, choice: \"research\" | \"dismiss\" | \"resume\") => void;\n\tonRetryLink: (offerId: string) => 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.status !== \"linked\") {\n\t\t\ttracker.retries = 0;\n\t\t\ttracker.status = \"checking\";\n\t\t\tthis.#links[id] = { status: \"checking\" };\n\t\t\tthis.#publish();\n\t\t}\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\tlet canRetryLink = link?.status === \"error\" && link.exhausted && controls.canCheckLink;\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\t{canRetryLink && (\n\t\t\t\t\t\t\t controls.onRetryLink(offer.id)}\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\tRetry link check\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","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",1794599122794,"sidebar","expanded"]