[{"_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","9261fa6bc6db0b65e9821e9d9656d98efbc7961d","path","apps/web/src/chat/chat.tsx","oid","cab45f0d8f874d8979d7e070530f71fe4571cabd","size",35914,"commit","mounts",[],"source","plain",{"_13":14,"_15":16},"kind","text","/**\n * The chat pane.\n *\n * Drives the agent, and shows what it is doing. The composer stays live while\n * a turn runs — a turn owns the plan, not the chat — and anything sent\n * to the agent meanwhile is queued in order, with its author's name on it, so\n * nobody is silenced because a colleague prompted first.\n */\n\nimport { useEffect, useId, useLayoutEffect, useReducer, useRef, useState } from \"react\";\n\nimport {\n\tCONNECTION_GRACE,\n\tMAX_RESEARCH_BRIEF,\n\tSendAction,\n\tuseConnectionNotice,\n\tusePopoverDismissal,\n} from \"@chopin/editor\";\nimport { MENTION } from \"@chopin/protocol/address\";\nimport { ArchiveIcon, InfoIcon, LockIcon, PlusIcon, WarningIcon } from \"@chopin/icons\";\nimport { DraftInput } from \"./draft-input\";\nimport type { DraftInputHandle } from \"./draft-input\";\nimport { ModeSwitch } from \"./mode-switch\";\nimport \"./composer.css\";\n\nimport { CommandPicker } from \"./command-picker\";\nimport {\n\tCHAT_COMMANDS,\n\tcommandBrief,\n\tcommandKeyAction,\n\tcommandText,\n\tcommandTrigger,\n\tcommandTriggerKey,\n\tdraftCommand,\n\tfilterCommands,\n} from \"./commands\";\nimport { MentionPicker } from \"./mention-picker\";\nimport {\n\tchatAuthors,\n\tfilterMentions,\n\tinsertMention,\n\tmentionCandidates,\n\tmentionKeyAction,\n\tmentionTrigger,\n\tmentionTriggerKey,\n} from \"./mentions\";\nimport {\n\treferenceOptionId,\n\tReferencePicker,\n\treferencePickerKeyAction,\n\tuseReferencePicker,\n} from \"./reference-picker\";\nimport {\n\tacknowledgeDraft,\n\taddressedOutsideReferences,\n\taddressesPlanner,\n\tboundedChatError,\n\tchatSendPayload,\n\tinsertReference,\n\tMAX_REFERENCES,\n\tPLANNER_UNAVAILABLE_NOTICE,\n\tprepareDraftSubmission,\n\treconcileReferenceDrafts,\n\treferenceTrigger,\n\treferenceTriggerKey,\n\treviseComposerDraft,\n\twithNoticesAfter,\n} from \"./references\";\nimport { RunStack } from \"./run-card\";\nimport { Transcript } from \"./transcript\";\nimport { initialTranscript, transcriptReducer } from \"./transcript-state\";\nimport type { TranscriptDecisions } from \"./transcript\";\nimport type { CardLink } from \"../conversation-plan/links\";\nimport type { ExcerptCorrectionAction } from \"../conversation-plan/analysis-overview\";\nimport type { ChatDestination } from \"../conversation-plan/source\";\nimport type { ResearchOfferControls } from \"./research-offer\";\nimport plannerStop from \"../assets/icons/planner-stop.svg\";\nimport plannerResume from \"../assets/icons/planner-resume.svg\";\n\nimport type { Chat as Wire, ConversationPlan } from \"@chopin/protocol\";\nimport type { Repository } from \"../api\";\nimport type { ResearchLaunchBlock, ResearchLaunchResult } from \"@chopin/editor\";\nimport type { ChatCommand } from \"./commands\";\nimport type { MentionCandidate } from \"./mentions\";\nimport type { ComposerDraft, ReferenceTarget } from \"./references\";\nimport type { Wire as Socket } from \"../wire\";\n\nexport type ChatProps = {\n\twire: Socket | undefined;\n\thandle: string;\n\tconnected: boolean;\n\treadonly?: boolean;\n\tarchived?: boolean;\n\treferencesEnabled: boolean;\n\trepository: Pick;\n\troom: string;\n\tsendAcknowledgements: boolean;\n\t/** People connected to this document, for `@` suggestions. */\n\tpeople?: readonly string[];\n\t/** Hosted mode keeps the shared chat while repository-scoped agent work is disabled. */\n\tagent?: boolean;\n\tactive?: boolean;\n\tonActivity?: (event: { type: \"message\" | \"working\"; busy: boolean }) => void;\n\tconversationPlan?: ConversationPlan.State;\n\tconversationPlanJobs?: ConversationPlan.Job[];\n\tonCardLink?: (link: CardLink) => void;\n\tonAddExcerpt?: (action: ExcerptCorrectionAction) => Promise;\n\tonRetryAnalysis?: (\n\t\tmessageId: string,\n\t\tactionId: string,\n\t\tlane?: \"decision\" | \"research\",\n\t) => Promise;\n\tonRetryJob?: (jobId: string) => Promise;\n\tdecisions?: TranscriptDecisions;\n\tresearchOffers?: ResearchOfferControls;\n\tsourceDestination?: ChatDestination;\n\t/** Opens Decisions, where a waiting workflow's questions are. */\n\tonShowDecisions?: () => void;\n\t/**\n\t * Opens the document's research composer with this brief, when this\n\t * document offers research, and says why when it cannot.\n\t */\n\tonResearch?: (brief: string) => Promise;\n\t/** Focuses the research draft already open in the document. */\n\tonShowResearch?: () => void;\n\t/** Replaces the composer when this viewer cannot chat at all, such as in an archived document. */\n\tnotice?: string;\n\t/** One calm line shown while the transcript has loaded and is still empty. */\n\temptyNotice?: string;\n};\n\n/** How many runs are still live, and how many are paused and resumable. */\nexport function runCounts(runs: Wire.Runs | undefined): { active: number; paused: number } {\n\tlet list = runs ?? [];\n\treturn {\n\t\tactive: list.filter(run => run.status === \"running\" || run.status === \"waiting\").length,\n\t\tpaused: list.filter(run => run.status === \"paused\").length,\n\t};\n}\n\nfunction draftKey(room: string): string {\n\treturn `chopin:chat-draft:${room}`;\n}\n\n/** Holds an unsent message across a reload of this tab; storage may refuse. */\nfunction keepDraft(room: string, draft: ComposerDraft): void {\n\ttry {\n\t\tif (!draft.text.trim()) return sessionStorage.removeItem(draftKey(room));\n\t\tsessionStorage.setItem(\n\t\t\tdraftKey(room),\n\t\t\tJSON.stringify({ text: draft.text, references: draft.references }),\n\t\t);\n\t} catch {\n\t\t// Private windows and blocked storage: the draft is lost as it was before.\n\t}\n}\n\n/** The message a reload interrupted; anything malformed starts empty. */\nfunction restoreDraft(room: string): ComposerDraft {\n\tlet empty = { text: \"\", references: [] };\n\ttry {\n\t\tlet raw = sessionStorage.getItem(draftKey(room));\n\t\tif (!raw) return empty;\n\t\tlet saved = JSON.parse(raw) as Partial;\n\t\tif (typeof saved.text !== \"string\") return empty;\n\t\tlet references = Array.isArray(saved.references)\n\t\t\t\t&& saved.references.every(reference =>\n\t\t\t\t\ttypeof reference?.start === \"number\" && typeof reference.end === \"number\"\n\t\t\t\t\t&& reference.end <= saved.text!.length\n\t\t\t\t)\n\t\t\t? saved.references\n\t\t\t: [];\n\t\treturn { text: saved.text, references };\n\t} catch {\n\t\treturn empty;\n\t}\n}\n\nexport function Chat(\n\t{\n\t\tactive = true,\n\t\tagent = true,\n\t\treadonly = false,\n\t\tarchived = false,\n\t\tconnected,\n\t\thandle,\n\t\tonActivity,\n\t\tconversationPlan,\n\t\tconversationPlanJobs,\n\t\tonCardLink,\n\t\tonAddExcerpt,\n\t\tonRetryAnalysis,\n\t\tonRetryJob,\n\t\tdecisions,\n\t\tresearchOffers,\n\t\tsourceDestination,\n\t\tpeople = [],\n\t\tnotice,\n\t\temptyNotice,\n\t\tonShowDecisions,\n\t\tonResearch,\n\t\tonShowResearch,\n\t\treferencesEnabled,\n\t\trepository,\n\t\troom,\n\t\tsendAcknowledgements,\n\t\twire,\n\t}: ChatProps,\n) {\n\tlet [transcript, dispatchTranscript] = useReducer(transcriptReducer, initialTranscript);\n\tlet { entries, turn } = transcript;\n\tlet [queue, setQueue] = useState([]);\n\tlet [unanswered, setUnanswered] = useState>({});\n\tlet [busy, setBusy] = useState(false);\n\tlet [runs, setRuns] = useState();\n\tlet counts = runCounts(runs);\n\tlet [draft, setDraft] = useState(() => restoreDraft(room));\n\tlet [submitting, setSubmitting] = useState(false);\n\t// A send pressed during a blip, made once the connection is back.\n\tlet [held, setHeld] = useState(false);\n\tlet sending = submitting || held;\n\tlet [sendError, setSendError] = useState();\n\tlet [researchBlock, setResearchBlock] = useState();\n\tlet researching = useRef(false);\n\tlet [selection, setSelection] = useState({ start: 0, end: 0 });\n\tlet [dismissedPicker, setDismissedPicker] = useState();\n\tlet [mentionCursor, setMentionCursor] = useState<{ key?: string; index: number }>({ index: 0 });\n\tlet [commandCursor, setCommandCursor] = useState<{ key?: string; index: number }>({ index: 0 });\n\tlet textarea = useRef(null);\n\tlet composerRoot = useRef(null);\n\tlet [mode, setMode] = useState(false);\n\tlet [historyKey, setHistoryKey] = useState(0);\n\tlet pendingCaret = useRef(undefined);\n\tlet submission = useRef