{"version":3,"file":"client.inner.cjs","names":["useSyncExternalStore","useCallback","useRef","useState","useRef","Button","StateDot","useId","Switch","Input"],"sources":["../../dsh-plugin-kit/src/contracts.ts","../../dsh-plugin-kit/src/client-utils.ts","../../dsh-plugin-kit/src/model-menu.ts","../../dsh-plugin-kit/src/official-ui.ts","../src/contracts.ts","../src/idle.ts","../src/client.tsx"],"sourcesContent":["import type { ContextFormed } from '@deepseek-ai/dsh-llm'\n\n/** Public, browser-safe contracts. Host implementations stay in their owning packages. */\nexport type ProducerSourceKind = `plugin:${string}`\nexport type ProducerMessageSource = { kind: ProducerSourceKind; plugin: string } & ContextFormed\n\n/**\n * V4 sessions persist the producing extension in `kind`; the retired generic\n * `plugin` wrapper is not admitted. Each feature plugin declares its own kind.\n */\ndeclare module '@deepseek-ai/dsh-llm' {\n interface MessageSourceMap {\n [kind: ProducerSourceKind]: ProducerMessageSource\n }\n}\n\nexport function producerMessageSource(plugin: string): ProducerMessageSource {\n return { kind: `plugin:${plugin}`, plugin }\n}\n\n/** A concrete provider model. Features store this on their own settings page. */\nexport interface ModelRoute { provider: string; model: string; reasoningEffort?: string }\n\n/** @deprecated Legacy call shape. Features should call host `llm` directly. */\nexport type ModelRole = 'normal' | 'weak' | 'strong' | 'fantasy'\n/** @deprecated Legacy call shape. Features should call host `llm` directly. */\nexport type ModelTarget = { kind: 'role'; role: ModelRole } | { kind: 'session' } | ({ kind: 'model' } & ModelRoute)\n/** @deprecated Legacy call shape. Features should call host `llm` directly. */\nexport interface AiPolicy {\n revision: number\n roles: Partial>\n purposes: Record\n limits: { concurrency: number; timeoutMs: number; maxInputChars: number; maxOutputTokens: number; maxAttempts: number }\n}\n/** @deprecated Legacy call shape. Features should call host `llm` directly. */\nexport interface PurposeSpec {\n id: string\n label: string\n defaultTarget: ModelTarget\n maxOutputTokens?: number\n maxInputChars?: number\n timeoutMs?: number\n}\n/** @deprecated Legacy call shape. Features should call host `llm` directly. */\nexport interface ResolvedRoute extends ModelRoute {\n source: 'override' | 'purpose' | 'default'\n target: ModelTarget\n policyRevision: number\n inheritedRole?: ModelRole\n}\n/** @deprecated Legacy call shape. Features should call host `llm` directly. */\nexport interface AuxiliaryRequest {\n purpose: string\n sessionId?: string\n input: string\n system: string\n sourceVersion: string\n contractVersion?: number\n promptVersion?: string\n schemaVersion?: string\n override?: ModelTarget\n signal?: AbortSignal\n isCurrent?: () => boolean\n priority?: 'interactive' | 'background'\n insert?: { maxChars: number }\n}\n/** @deprecated Legacy call shape. Features should call host `llm` directly. */\nexport interface UsageReceipt {\n id: string\n plugin: string\n purpose: string\n sessionId?: string\n sourceVersion: string\n contractVersion?: number\n promptVersion?: string\n schemaVersion?: string\n route?: ResolvedRoute\n status: 'success' | 'failed' | 'cancelled' | 'superseded' | 'skipped'\n attempts: number\n inputTokens?: number\n outputTokens?: number\n cost: number | null\n startedAt: number\n finishedAt: number\n error?: string\n}\n/** @deprecated Legacy call shape. Features should call host `llm` directly. */\nexport interface AuxiliaryResult { text: string; receipt: UsageReceipt }\n/** @deprecated Legacy call shape. Features should call host `llm` directly. */\nexport interface AiFeatureScope {\n readonly plugin: string\n readonly signal: AbortSignal\n readonly active: boolean\n registerPurpose(spec: PurposeSpec): () => void\n run(request: AuxiliaryRequest): Promise\n dispose(): void\n}\n/** @deprecated Legacy call shape. Features should call host `llm` directly. */\nexport interface AiServices {\n activate(plugin: string): AiFeatureScope\n importPurposes(migrationId: string, defaults: Record, roles?: AiPolicy['roles']): Promise\n getPolicy(): AiPolicy\n updatePolicy(policy: Omit, expectedRevision: number): Promise\n resolve(purpose: string, sessionId?: string, override?: ModelTarget): Promise\n purposes(): Array\n usage(): UsageReceipt[]\n}\n\nexport type RpcResult = { ok: true; value: T } | { ok: false; error: { code: string; message: string } }\nexport const CHAT_EVENTS_SLOT = 'dsh-editor.chat.events'\nexport interface EvidenceRef { sessionId: string; seq: number; kind: 'user' | 'tool' | 'turn' | 'manual'; excerpt?: string }\nexport interface TaskContract {\n id: string\n sessionId: string\n sourceVersion: string\n revision: number\n goal: string\n deliverables: string[]\n inScope: string[]\n outOfScope: string[]\n constraints: string[]\n acceptance: string[]\n assumptions: string[]\n questions: string[]\n evidence: EvidenceRef[]\n readiness: 'pending' | 'clear-request' | 'user-confirmed' | 'disclosed-assumptions' | 'cancelled' | 'stale'\n updatedAt: number\n}\nexport interface TaskCheckpoint {\n id: string\n sessionId: string\n sourceVersion: string\n contractVersion?: number\n fromSeq: number\n toSeq: number\n revision: number\n status: 'running' | 'completed' | 'failed' | 'cancelled'\n items: Array<{ label: string; state: 'pending' | 'verified' | 'failed'; evidence: EvidenceRef[] }>\n constraints: string[]\n nextAction: string\n createdAt: number\n}\nexport type KnowledgeScope = { kind: 'global' } | { kind: 'project'; projectId: string }\nexport type KnowledgeKind = 'preference' | 'project-fact' | 'decision' | 'vocabulary' | 'activity' | 'lesson'\n/** Descriptive context, never an executable instruction or authorization. */\nexport interface ContextKnowledge {\n subject: string\n domain: string\n key: string\n aliases: string[]\n observedAt: number\n /** The user's own time expression, not an inferred completion date. */\n eventTime?: string\n activityStatus?: 'planned' | 'in-progress' | 'blocked' | 'paused' | 'completed' | 'cancelled' | 'unknown'\n}\n/** A scoped method. Observations remain candidates until explicitly accepted. */\nexport interface ProcedureKnowledge {\n origin: 'instruction' | 'observation'\n goal: string\n when: string[]\n steps: string[]\n avoid: string[]\n verify: string[]\n}\nexport interface MemoryRecord {\n id: string\n revision: number\n scope: KnowledgeScope\n kind: KnowledgeKind\n status: 'candidate' | 'active' | 'rejected' | 'superseded' | 'revoked' | 'deleted'\n title: string\n content: string\n tags: string[]\n evidence: EvidenceRef[]\n exceptions: string[]\n source: 'user' | 'memory' | 'dream' | 'self-improvement'\n context?: ContextKnowledge\n procedure?: ProcedureKnowledge\n createdAt: number\n updatedAt: number\n expiresAt?: number\n supersedes?: string[]\n /** Exact record revisions behind a derived candidate; revalidated on adoption. */\n basis?: Array<{ id: string; revision: number }>\n}\nexport type NewMemoryRecord = Omit\nexport interface MemoryQuery { scope: KnowledgeScope; query?: string; kinds?: KnowledgeKind[]; statuses?: MemoryRecord['status'][]; limit?: number }\nexport interface MemoryMutationOptions { signal?: AbortSignal; isCurrent?: () => boolean }\nexport interface MemoryService {\n list(query: MemoryQuery): Promise\n create(record: NewMemoryRecord, options?: MemoryMutationOptions): Promise\n update(id: string, patch: Partial>, expectedRevision: number, options?: MemoryMutationOptions): Promise\n /** Explicit user promotion, persisted atomically on the same record; preserves expiry and evidence. */\n promoteToGlobal(id: string, expectedRevision: number, options?: MemoryMutationOptions): Promise\n remove(id: string, expectedRevision: number, options?: MemoryMutationOptions): Promise\n recall(query: MemoryQuery): Promise\n}\n\n/**\n * The session creation metadata the host snapshots when it creates a delegated child\n * thread. Mirrors `CreateAgentOptions.meta` in `@deepseek-ai/dsh-agent`; it is durable\n * session data, so it survives a restart and needs no ancestry walk.\n */\nexport interface SubagentSessionLike {\n readonly header?: {\n readonly parentSession?: unknown\n readonly origin?: unknown\n readonly delegationDepth?: unknown\n }\n}\n\n/**\n * True when `session` is a delegated child thread rather than a human-driven top-level\n * conversation.\n *\n * A message's `source.kind === 'user'` cannot answer this: a lead agent's dispatch prompt\n * is delivered as the child's own user message, so delegated work is indistinguishable\n * from a person typing once you only look at the message. Plugins use this to keep\n * automatic writes and derived model calls on top-level sessions.\n */\nexport function isSubagentSession(session: unknown): boolean {\n const header = (session as SubagentSessionLike | null | undefined)?.header\n if (!header || typeof header !== 'object') return false\n return Boolean(header.parentSession)\n || header.origin === 'subagent'\n || Number(header.delegationDepth ?? 0) > 0\n}\n\n/** Project keys come only from the host-validated session directory, never client input. */\nexport function projectIdFromCwd(cwd: string | undefined): string | undefined {\n if (typeof cwd !== 'string') return undefined\n const normalized = cwd.trim().replaceAll('\\\\', '/')\n if (!normalized) return undefined\n return normalized === '/' || /^[A-Za-z]:\\/$/.test(normalized) ? normalized : normalized.replace(/\\/+$/, '')\n}\n","import { useCallback, useEffect, useRef, useSyncExternalStore } from 'react'\n\nexport interface NativeSurfaceClient {\n sessions: {\n binding?(sessionId: string): { eventSource: { subscribe(listener: () => void): () => void } } | undefined\n }\n uiWorkspace: { current?: { getSnapshot(): { sessionId: string } | undefined; subscribe(listener: () => void): () => void } }\n uiSession: { adapter: { current: { getSnapshot(): { key?: string }; subscribe(listener: () => void): () => void } } }\n locale: { getSnapshot(): { active: string }; subscribe(listener: () => void): () => void }\n connection?: { generation?: { subscribe(listener: () => void): () => void } }\n}\n\n/** The Editor retains its manuscript session separately; native DSH exposes the main-view binding. */\nexport function selectedSessionId(client: Pick): string {\n const workspace = client.uiWorkspace?.current\n return workspace\n ? workspace.getSnapshot()?.sessionId ?? ''\n : client.uiSession.adapter.current.getSnapshot().key ?? ''\n}\n\n/**\n * Owner props are data the host composed, never a Cordis context: reading an\n * undeclared property off one throws instead of returning undefined, which\n * would crash the slot entry and abdicate its cell for good. Tolerate a\n * throwing read so a mistaken prop degrades to \"not supplied\".\n */\nfunction read(source: unknown, key: string): unknown {\n if (source === null || typeof source !== 'object') return undefined\n try {\n return (source as Record)[key]\n } catch {\n return undefined\n }\n}\n\nfunction readString(source: unknown, key: string): string | undefined {\n const value = read(source, key)\n return typeof value === 'string' ? value : undefined\n}\n\n/** Owner props win; native settings only supplies close, so resolve its selected session. */\nexport function useNativeSeat(client: NativeSurfaceClient, props?: unknown) {\n const current = useSyncExternalStore(\n useCallback((fn: () => void) => (client.uiWorkspace?.current ?? client.uiSession.adapter.current).subscribe(fn), [client]),\n useCallback(() => selectedSessionId(client), [client]),\n () => '',\n )\n const language = useSyncExternalStore(\n useCallback((fn: () => void) => client.locale.subscribe(fn), [client]),\n useCallback(() => client.locale.getSnapshot().active, [client]),\n () => 'en',\n )\n const sessionId = readString(props, 'sessionId') ?? readString(read(props, 'owner'), 'sessionId') ?? current\n const requestedLocale = read(props, 'locale') ?? read(read(props, 'owner'), 'locale') ?? language\n return { sessionId, locale: (String(requestedLocale).startsWith('zh') ? 'zh' : 'en') as 'zh' | 'en',\n hidden: read(props, 'hidden') === true || read(read(props, 'owner'), 'hidden') === true }\n}\n\n/** Refresh on native log boundaries/reconnect/focus. Read-only settling is bounded to an observed job. */\nexport function useFeatureRefresh(\n client: NativeSurfaceClient, sessionId: string, refresh: () => void,\n working = false, enabled = true,\n): void {\n const refreshRef = useRef(refresh)\n refreshRef.current = refresh\n useEffect(() => {\n if (!enabled) return\n let timer: ReturnType | undefined\n const queue = () => {\n if (typeof document !== 'undefined' && document.visibilityState === 'hidden') return\n clearTimeout(timer)\n timer = setTimeout(() => refreshRef.current(), 150)\n }\n const source = sessionId ? client.sessions.binding?.(sessionId)?.eventSource : undefined\n const stopEvents = source?.subscribe(queue)\n const stopConnection = client.connection?.generation?.subscribe(queue)\n const visibility = () => { if (document.visibilityState === 'visible') queue() }\n window.addEventListener('focus', queue)\n document.addEventListener('visibilitychange', visibility)\n // Details are collapsed by default; opening an existing panel must get current state.\n document.addEventListener('toggle', queue, true)\n return () => {\n clearTimeout(timer)\n stopEvents?.(); stopConnection?.()\n window.removeEventListener('focus', queue)\n document.removeEventListener('visibilitychange', visibility)\n document.removeEventListener('toggle', queue, true)\n }\n }, [client, sessionId, enabled])\n useEffect(() => {\n if (!enabled || !working) return\n let delay = 250\n const until = Date.now() + 300_000\n let timer: ReturnType\n const tick = () => {\n if (Date.now() >= until) return\n if (document.visibilityState !== 'hidden') refreshRef.current()\n delay = Math.min(delay * 2, 2000)\n timer = setTimeout(tick, delay)\n }\n timer = setTimeout(tick, delay)\n return () => clearTimeout(timer)\n }, [client, sessionId, working, enabled])\n}\n","/**\n * Shared plugin-page model menu.\n *\n * A feature plugin's own settings row exposes a model select. An empty\n * selection means the host default chat model for that feature's own call.\n *\n * Browser-safe and React-optional: pure helpers live here so hosts and clients\n * share one catalog contract without bundling React into the host build.\n */\nimport { useEffect, useState } from 'react'\nimport type { ModelRoute } from './contracts.ts'\n\n/** One selectable model. `efforts` are the advertised reasoning efforts. */\nexport interface ModelMenuChoice {\n readonly provider: string\n readonly model: string\n readonly label: string\n readonly efforts: ReadonlyArray<{ id: string; name: string }>\n}\n\n/** The stored selection. Empty provider/model means \"follow the default\". */\nexport type ModelMenuRoute = ModelRoute\n\n/** The catalog face this helper needs; stays structural so hosts may add more. */\nexport interface ModelCatalogClient {\n readonly remote?: {\n readonly session?: { readonly modelCatalog?: () => Promise }\n }\n}\n\nconst KEY_SEPARATOR = '\\u001f'\n\nexport function modelMenuChoiceKey(provider: string, model: string): string {\n return provider && model ? `${provider}${KEY_SEPARATOR}${model}` : ''\n}\n\nexport function parseModelMenuChoiceKey(value: string): { provider: string; model: string } | undefined {\n const index = value.indexOf(KEY_SEPARATOR)\n if (index <= 0) return undefined\n const provider = value.slice(0, index)\n const model = value.slice(index + KEY_SEPARATOR.length)\n if (!provider || !model) return undefined\n return { provider, model }\n}\n\nfunction asRecord(value: unknown): Record | undefined {\n return value && typeof value === 'object' && !Array.isArray(value) ? value as Record : undefined\n}\n\nfunction asText(value: unknown): string | undefined {\n return typeof value === 'string' && value.trim() ? value.trim() : undefined\n}\n\nfunction parseEffort(value: unknown): { id: string; name: string } | undefined {\n const row = asRecord(value)\n const id = row ? asText(row.id) : undefined\n if (!id) return undefined\n return { id, name: row ? asText(row.name) ?? id : id }\n}\n\n/** Parse the host session catalog into flat choices, keeping a saved route selectable. */\nexport function parseModelMenuChoices(value: unknown, bound?: ModelMenuRoute): ModelMenuChoice[] {\n const envelope = asRecord(value)\n // Host remote calls resolve to a result envelope ({ ok, value }); older hosts\n // and unit tests hand over the bare catalog. Accept both.\n const root = (envelope && envelope.ok === true ? asRecord(envelope.value) : undefined) ?? envelope ?? {}\n const groups = Array.isArray(root.groups) ? root.groups : []\n const choices: ModelMenuChoice[] = []\n for (const group of groups) {\n const groupRow = asRecord(group)\n const provider = groupRow ? asText(groupRow.id) : undefined\n if (!provider || !groupRow || !Array.isArray(groupRow.models)) continue\n const providerName = asText(groupRow.name) ?? provider\n for (const entry of groupRow.models) {\n const modelRow = asRecord(entry)\n const model = modelRow ? asText(modelRow.id) : undefined\n if (!model || !modelRow) continue\n const name = asText(modelRow.name) ?? model\n const reasoning = asRecord(modelRow.reasoning)\n const efforts = reasoning && Array.isArray(reasoning.efforts)\n ? reasoning.efforts.flatMap(effort => { const parsed = parseEffort(effort); return parsed ? [parsed] : [] })\n : []\n choices.push({ provider, model, label: `${providerName} / ${name}`, efforts })\n }\n }\n if (bound?.provider && bound.model && !choices.some(item => item.provider === bound.provider && item.model === bound.model)) {\n choices.push({ provider: bound.provider, model: bound.model, label: `${bound.provider} / ${bound.model}`, efforts: [] })\n }\n return choices\n}\n\n/** An empty saved route means no explicit model. */\nexport function modelMenuOverride(route: ModelMenuRoute | undefined): ModelRoute | undefined {\n const provider = route?.provider?.trim()\n const model = route?.model?.trim()\n if (!provider || !model) return undefined\n const effort = route?.reasoningEffort?.trim()\n return effort ? { provider, model, reasoningEffort: effort } : { provider, model }\n}\n\nexport function normalizeModelMenuRoute(value: unknown): ModelMenuRoute {\n const row = asRecord(value)\n if (!row) return { provider: '', model: '' }\n const provider = asText(row.provider) ?? ''\n const model = asText(row.model) ?? ''\n const effort = asText(row.reasoningEffort)\n if (!provider || !model || provider.length > 250 || model.length > 250) return { provider: '', model: '' }\n return effort && effort.length <= 80 ? { provider, model, reasoningEffort: effort } : { provider, model }\n}\n\n/** Load the host catalog once per mount and republish whenever it answers. */\nexport function useModelMenuChoices(client: ModelCatalogClient, bound?: ModelMenuRoute): ModelMenuChoice[] {\n const [choices, setChoices] = useState([])\n useEffect(() => {\n if (typeof document === 'undefined') return\n let live = true\n const load = () => {\n void client.remote?.session?.modelCatalog?.()\n ?.then(value => { if (live) setChoices(parseModelMenuChoices(value, bound)) })\n .catch(() => { if (live) setChoices([]) })\n }\n load()\n return () => { live = false }\n }, [client, bound?.provider, bound?.model])\n return choices\n}\n\n/** Reasoning-effort options for one choice; the saved value stays selectable. */\nexport function modelMenuEffortOptions(\n choice: ModelMenuChoice | undefined,\n current?: string,\n): Array<{ id: string; name: string }> {\n const listed = (choice?.efforts ?? []).map(item => ({ ...item }))\n if (current && !listed.some(item => item.id === current)) listed.push({ id: current, name: current })\n return listed\n}\n","/**\n * Shared contract that keeps every plugin's browser-side UI on the official\n * DeepSeek Harness Web design language.\n *\n * Two rules produce that language, and both are load-bearing here:\n *\n * 1. Colour, radius, elevation and focus come from the host theme's real\n * `--dsw-*` tokens, written under their own names. Plugins never invent a\n * token, never alias the official ones behind a private palette (a private\n * alias is just a second, diverging theme), and never carries a literal\n * fallback — the host publishes light and dark, and a literal would pin one\n * of them. The only non-colour custom properties used are the host's own\n * content-font axis and frame clearance.\n *\n * 2. Anything the host already ships is used, not reimplemented. Controls come\n * from `@deepseek-ai/dsh-client-ui-primitives` (`Button`, `Input`,\n * `Checkbox`, `Switch`, `Tag`, `Pill`, `SegmentedControl`, `Menu`, `Modal`,\n * `Tooltip`, `Toast`, `DisclosureRow`, `StateDot`, `PathLabel`, the settings\n * form suite). This module only styles what primitives do not cover: page\n * scaffolding, field layout, banners, empty states and scroll regions.\n *\n * The metrics below are transcribed from the primitives' own CSS modules so a\n * feature panel lines up pixel-for-pixel with a native one: the 14/22 body and\n * 13/20 compact type tiers, the 0.5px hairline scale, and the elevation family\n * that draws a surface's edge in its shadow (`border: 0`) instead of a border.\n */\n\n/**\n * Every `--dsw-*` token this repo is allowed to reference, grouped by role.\n *\n * Plugins may only colour through this list. It is exported so the guard test\n * can fail a build when a stylesheet reaches for anything else — the failure\n * mode this prevents is silent: an unknown token resolves to nothing, so a\n * border disappears or a label inherits the wrong colour with no error anywhere.\n */\nexport const OFFICIAL_THEME_TOKENS = {\n /** Surfaces, from the page up to the topmost nested card. */\n surface: [\n '--dsw-alias-bg-base',\n '--dsw-alias-bg-layer-1',\n '--dsw-alias-bg-layer-2',\n '--dsw-alias-bg-layer-3',\n '--dsw-alias-bg-layer-4',\n '--dsw-alias-bg-module-platform',\n '--dsw-alias-bg-overlay',\n ],\n /** Hairlines. l1 is near-invisible on a menu surface, so menus use l2+. */\n border: ['--dsw-alias-border-l1', '--dsw-alias-border-l2', '--dsw-alias-border-l3', '--dsw-alias-border-l4'],\n /** Text. `caption` is menu shortcut text, `dimmed` is placeholder text. */\n label: [\n '--dsw-alias-label-primary',\n '--dsw-alias-label-secondary',\n '--dsw-alias-label-tertiary',\n '--dsw-alias-label-caption',\n '--dsw-alias-label-dimmed',\n '--dsw-alias-label-error',\n '--dsw-alias-label-primary-foreground',\n ],\n /** Interactive fills. The `-danger` hover belongs to destructive rows. */\n interactive: [\n '--dsw-alias-interactive-bg-hover',\n '--dsw-alias-interactive-bg-active',\n '--dsw-alias-interactive-bg-hover-danger',\n ],\n /** Accent and status. `business` is the focus ring's default colour. */\n accent: [\n '--dsw-alias-brand-primary',\n '--dsw-alias-button-primary-fill',\n '--dsw-alias-button-primary-hover',\n '--dsw-alias-button-tool-bar-fill',\n '--dsw-alias-button-tool-bar-hover',\n '--dsw-alias-button-ghost-active-fill',\n '--dsw-alias-button-ghost-active-border',\n ],\n state: [\n '--dsw-alias-state-business-primary',\n '--dsw-alias-state-success-primary',\n '--dsw-alias-state-warn-primary',\n '--dsw-alias-state-error-primary',\n '--dsw-alias-state-idle-primary',\n ],\n /** Corner scale: sm 8, md 12, lg the large card, panel the modal. */\n radius: ['--dsw-radius-sm', '--dsw-radius-md', '--dsw-radius-lg', '--dsw-radius-panel'],\n /** An elevated surface draws its edge in the shadow, so it keeps border: 0. */\n elevation: [\n '--dsw-elevation-soft',\n '--dsw-elevation-stroke',\n '--dsw-elevation-stroke-color',\n '--dsw-elevation-panel',\n '--dsw-elevation-prominent',\n ],\n /** Floats, masks and scrollbars. */\n overlay: [\n '--dsw-menu-surface-fill',\n '--dsw-menu-backdrop-filter',\n '--dsw-mask-blur',\n '--dsw-alias-bg-mask-1',\n '--dsw-alias-menu-icon',\n '--dsw-alias-scrollbar-bg-l2',\n '--dsw-alias-scrollbar-hover-l2',\n '--dsw-shadow-lv3',\n ],\n /** Motion, focus and type axis, published by the host rather than by a component. */\n system: [\n '--dsw-focus-ring-width',\n '--dsw-focus-ring-color',\n '--dsw-font-markdown-code-font-family',\n '--ds-transition-duration',\n '--ds-ease-in-out',\n '--ds-font-family-code',\n '--dsh-scrollbar-thumb',\n '--dsh-scrollbar-thumb-hover',\n '--dsh-content-font-size-secondary',\n '--dsh-content-font-delta',\n '--dsh-frame-top-clearance',\n ],\n} as const\n\n/** Every official token name, flat. Used by the token guard test. */\nexport const OFFICIAL_THEME_TOKEN_NAMES: readonly string[] = Object.values(OFFICIAL_THEME_TOKENS).flat()\n\n/** The elevation steps a surface can be raised by, softest first. */\nexport type OfficialElevation = 'soft' | 'stroke' | 'panel' | 'prominent'\n\n/**\n * The host's focus ring shorthand, verbatim. Writing this per control is how\n * rings drift apart; a stylesheet that draws its own focus style should use\n * {@link officialFocus} instead. The colour fallback is the host's own default.\n */\nexport const OFFICIAL_FOCUS_RING =\n 'var(--dsw-focus-ring-width) solid var(--dsw-focus-ring-color, var(--dsw-alias-state-business-primary))'\n\n/**\n * A complete `outline` declaration at the official geometry. `offset` defaults\n * to the 2px the native controls use; the host's inline field rules sit at 1px\n * and a segmented tab pulls the ring inside itself at -2px.\n */\nexport function officialFocus(offset = '2px'): string {\n return `outline: ${OFFICIAL_FOCUS_RING}; outline-offset: ${offset}`\n}\n\n/**\n * An elevated surface. The host draws a raised surface's edge inside its\n * shadow rather than as a border, so a card sets `border: 0` and takes the edge\n * from the elevation — which is also why its border stays off the alias-border\n * set that a flat, non-elevated rule would use.\n */\nexport function officialElevation(level: OfficialElevation): string {\n return `border: 0; box-shadow: var(--dsw-elevation-${level})`\n}\n\n/**\n * An elevated surface whose edge should read as a specific hairline. Rebinding\n * the stroke colour is how a menu card picks l1 while a panel picks l3, without\n * the two growing apart by hand.\n */\nexport function officialStrokedElevation(level: OfficialElevation, color: string): string {\n return `--dsw-elevation-stroke-color: ${color}; ${officialElevation(level)}`\n}\n\n/**\n * The shared stylesheet for a plugin UI, scoped under that plugin's root class.\n *\n * Scoping is what keeps this safe to always-bundle into every client: the rules\n * can only match inside the plugin's own subtree, so two plugins can both mount\n * `dsh-ui-card` without either styling the other's markup.\n *\n * Each recipe matches the root element *and* its descendants, because the\n * commonest arrangement is one element that is both — a surface that carries\n * the root class and `dsh-ui-card`, or a portaled dialog that is the root and\n * the `dsh-ui-surface`. A descendant-only scope would silently leave those\n * unstyled, with no error anywhere.\n *\n * A caveat worth knowing: `Modal` and `Menu` portal to `document.body`, so their\n * content leaves the plugin's subtree entirely. A portaled surface therefore\n * needs its own root class on an element inside the portal.\n *\n * Only patterns that primitives do not provide live here. If a control appears\n * below that `Button`/`Input`/`Switch`/`Tag`/`Menu` already covers, that is a\n * bug in this file: use the primitive and delete the recipe.\n */\nexport function officialUiCss(roots: string | readonly string[]): string {\n // One plugin often mounts several unrelated surfaces (a settings seat, a chat\n // card, a header menu), so the caller names every root. The rules below are\n // nested under a single selector list and use `&`, which the browser expands\n // per root — so one stylesheet covers all of them without duplicating itself.\n const scope = (typeof roots === 'string' ? [roots] : roots).map(root => `.${root}`).join(', ')\n const sheet = `\n/* Official DSH Web UI contract. Generated by @klarkxy/dsh-plugin-kit/official-ui.\n * Do not hand-edit the copy inside a plugin: change this module so every plugin\n * moves together. Scope: ${scope} */\n/* The scope rule below stays open for the whole sheet: every rule after it\n * nests with the parent selector, so one stylesheet can cover several unrelated\n * roots without leaking into a neighbouring plugin. Its closing brace is last. */\n${scope} {\n color: var(--dsw-alias-label-primary);\n font-family: inherit;\n font-size: 14px;\n line-height: 22px;\n min-width: 0;\n\n& *, & *::before, & *::after { box-sizing: border-box; }\n& h1, & h2, & h3, & h4, & p, & figure { margin: 0; }\n/* Keyboard focus only: pointer input keeps the native resting appearance. The\n * ring needs no radius of its own — the outline already follows the control's\n * own border-radius, and overriding it here would flatten every control. */\n& :focus-visible { ${officialFocus()}; }\n& [hidden] { display: none !important; }\n\n/* --- Type tiers. The same 14/22 and 13/20 steps the primitives use. --- */\n& .dsh-ui-title { font-size: 16px; line-height: 24px; font-weight: 500; color: var(--dsw-alias-label-primary); }\n& .dsh-ui-heading { font-size: 14px; line-height: 22px; font-weight: 500; color: var(--dsw-alias-label-primary); }\n& .dsh-ui-compact { font-size: 13px; line-height: 20px; color: var(--dsw-alias-label-primary); }\n& .dsh-ui-meta { font-size: 12px; line-height: 18px; color: var(--dsw-alias-label-secondary); }\n& .dsh-ui-hint { font-size: 12px; line-height: 18px; color: var(--dsw-alias-label-tertiary); }\n& .dsh-ui-error { font-size: 12px; line-height: 18px; color: var(--dsw-alias-state-error-primary); }\n& .dsh-ui-warn { color: var(--dsw-alias-state-warn-primary); }\n& .dsh-ui-success { color: var(--dsw-alias-state-success-primary); }\n& .dsh-ui-muted { color: var(--dsw-alias-label-tertiary); }\n& .dsh-ui-truncate { min-width: 0; overflow: hidden; text-overflow: ellipsis; white-space: nowrap; }\n& .dsh-ui-wrap { min-width: 0; overflow-wrap: anywhere; }\n\n/* --- Layout scaffolding. --- */\n& .dsh-ui-stack { display: flex; flex-direction: column; gap: 12px; }\n& .dsh-ui-stack-lg { display: flex; flex-direction: column; gap: 20px; }\n& .dsh-ui-row { display: flex; align-items: center; gap: 8px; min-width: 0; }\n& .dsh-ui-row-wrap { display: flex; align-items: center; flex-wrap: wrap; gap: 8px; }\n& .dsh-ui-spacer { flex: 1; min-width: 0; }\n/* A 0.5px l2 rule is the host's section divider; reserve the same rhythm. */\n& .dsh-ui-divider { height: 0.5px; background: var(--dsw-alias-border-l2); }\n& .dsh-ui-section { display: flex; flex-direction: column; gap: 12px; padding-top: 16px; border-top: 0.5px solid var(--dsw-alias-border-l2); }\n\n/* --- Card: a raised surface whose edge lives in the shadow. --- */\n& .dsh-ui-card {\n ${officialElevation('stroke')}\n display: flex;\n flex-direction: column;\n gap: 12px;\n padding: 16px;\n border-radius: var(--dsw-radius-lg);\n background: var(--dsw-alias-bg-layer-1);\n color: var(--dsw-alias-label-primary);\n min-width: 0;\n}\n& .dsh-ui-card--flat { border: 0.5px solid var(--dsw-alias-border-l3); box-shadow: none; }\n& .dsh-ui-card--nested { background: var(--dsw-alias-bg-layer-2); }\n& .dsh-ui-card--plain { background: none; }\n\n/* --- Field: label, control, help, error. The control itself is an\n * official primitive, so this only owns the vertical rhythm. --- */\n& .dsh-ui-field { display: flex; flex-direction: column; gap: 6px; min-width: 0; }\n& .dsh-ui-field + .dsh-ui-field { border-top: 0.5px solid var(--dsw-alias-border-l2); padding-top: 12px; }\n& .dsh-ui-label { display: flex; align-items: center; gap: 6px; font-size: 13px; line-height: 20px; font-weight: 500; color: var(--dsw-alias-label-primary); }\n& .dsh-ui-label-row { display: flex; align-items: baseline; justify-content: space-between; gap: 8px; }\n& .dsh-ui-help { font-size: 12px; line-height: 1.6; color: var(--dsw-alias-label-secondary); }\n& .dsh-ui-help p { margin: 0; }\n& .dsh-ui-help p + p { margin-top: 8px; }\n& .dsh-ui-required { color: var(--dsw-alias-state-error-primary); }\n& .dsh-ui-control { width: 100%; min-width: 0; }\n/* An invalid control is marked on the control, not only in the message. */\n& .dsh-ui-control[aria-invalid='true'] { border-color: var(--dsw-alias-state-error-primary); }\n& .dsh-ui-readonly { display: flex; flex-direction: column; gap: 4px; min-width: 0; }\n& .dsh-ui-readonly > dt { font-size: 12px; line-height: 18px; color: var(--dsw-alias-label-tertiary); }\n& .dsh-ui-readonly > dd { margin: 0; font-size: 13px; line-height: 20px; overflow-wrap: anywhere; }\n\n/* --- Buttons row. A no-op container: it exists so actions line up on the\n * trailing edge the way every native panel does. --- */\n& .dsh-ui-actions { display: flex; flex-wrap: wrap; align-items: center; gap: 8px; padding-top: 4px; }\n& .dsh-ui-actions-end { justify-content: flex-end; }\n\n/* --- Banners. A banner is a left-rail notice, the shape used for warnings,\n * deprecations and blocking instructions. --- */\n& .dsh-ui-banner {\n display: flex;\n flex-direction: column;\n gap: 8px;\n padding: 10px 14px;\n border: 0.5px solid var(--dsw-alias-border-l3);\n border-left: 3px solid var(--dsw-alias-state-warn-primary);\n border-radius: var(--dsw-radius-md);\n background: var(--dsw-alias-bg-layer-1);\n font-size: 13px;\n line-height: 20px;\n color: var(--dsw-alias-label-secondary);\n}\n& .dsh-ui-banner-title { font-weight: 500; color: var(--dsw-alias-state-warn-primary); }\n& .dsh-ui-banner--info { border-left-color: var(--dsw-alias-state-business-primary); }\n& .dsh-ui-banner--danger { border-left-color: var(--dsw-alias-state-error-primary); }\n& .dsh-ui-banner--success { border-left-color: var(--dsw-alias-state-success-primary); }\n& .dsh-ui-banner p { margin: 0; }\n\n/* --- Inline notice: a transient confirmation with no chrome of its own. --- */\n& .dsh-ui-notice { display: flex; align-items: center; gap: 6px; font-size: 12px; line-height: 18px; color: var(--dsw-alias-state-success-primary); }\n& .dsh-ui-notice--error { color: var(--dsw-alias-state-error-primary); }\n\n/* --- Empty and loading states. Both sit in a dashed well so an empty panel\n * reads as \"nothing here yet\" rather than as a broken layout. --- */\n& .dsh-ui-empty {\n display: flex;\n flex-direction: column;\n align-items: flex-start;\n gap: 6px;\n padding: 20px 16px;\n border: 0.5px dashed var(--dsw-alias-border-l3);\n border-radius: var(--dsw-radius-md);\n font-size: 13px;\n line-height: 20px;\n color: var(--dsw-alias-label-secondary);\n}\n& .dsh-ui-loading { display: flex; align-items: center; gap: 8px; padding: 20px 0; font-size: 13px; line-height: 20px; color: var(--dsw-alias-label-secondary); }\n\n/* --- Selectable list. A row is a button-sized target with a hover fill and\n * a selected fill; the name carries the weight, the description does not. --- */\n& .dsh-ui-list { list-style: none; margin: 0; padding: 0; display: flex; flex-direction: column; gap: 2px; min-width: 0; }\n& .dsh-ui-list-scroll { max-height: min(66vh, 760px); overflow-y: auto; overflow-x: hidden; }\n& .dsh-ui-list-row { border-radius: var(--dsw-radius-md); }\n& .dsh-ui-list-row:hover { background: var(--dsw-alias-interactive-bg-hover); }\n& .dsh-ui-list-row[aria-selected='true'], & .dsh-ui-list-row[data-selected] { background: var(--dsw-alias-interactive-bg-active); }\n& .dsh-ui-list-item {\n display: flex;\n flex-direction: column;\n align-items: flex-start;\n gap: 4px;\n width: 100%;\n min-width: 0;\n padding: 10px 12px;\n border: 0;\n border-radius: var(--dsw-radius-md);\n background: none;\n font: inherit;\n color: inherit;\n text-align: start;\n cursor: pointer;\n}\n& .dsh-ui-list-item:disabled { cursor: default; }\n& .dsh-ui-list-item:disabled:hover { background: none; }\n& .dsh-ui-list-name { font-size: 14px; line-height: 22px; font-weight: 500; color: var(--dsw-alias-label-primary); overflow-wrap: anywhere; }\n& .dsh-ui-list-desc { font-size: 12px; line-height: 18px; color: var(--dsw-alias-label-tertiary); }\n\n/* --- Code and structured output. Wraps rather than scrolls, because a\n * feature panel is read rather than scanned. --- */\n& .dsh-ui-code {\n padding: 10px 12px;\n border: 0.5px solid var(--dsw-alias-border-l3);\n border-radius: var(--dsw-radius-md);\n background: var(--dsw-alias-bg-layer-1);\n font-family: var(--ds-font-family-code, ui-monospace, 'Cascadia Mono', Consolas, monospace);\n font-size: 12px;\n line-height: 20px;\n color: var(--dsw-alias-label-secondary);\n overflow-wrap: anywhere;\n white-space: pre-wrap;\n}\n& .dsh-ui-scroll { max-height: 60vh; overflow: auto; overscroll-behavior: contain; }\n\n/* --- A toggle row: label on the left, switch on the trailing edge. This is\n * layout only; the switch itself is the official primitive. --- */\n& .dsh-ui-toggle-row { display: flex; align-items: center; justify-content: space-between; gap: 16px; min-width: 0; padding: 12px 0; }\n& .dsh-ui-toggle-row + .dsh-ui-toggle-row { border-top: 0.5px solid var(--dsw-alias-border-l2); }\n& .dsh-ui-toggle-text { display: flex; flex-direction: column; gap: 4px; min-width: 0; }\n& .dsh-ui-toggle-label { font-size: 14px; line-height: 22px; font-weight: 500; color: var(--dsw-alias-label-primary); }\n\n/* --- Floating surface: a panel anchored to a trigger. This is the material\n * a menu card is made of — the translucent fill plus its backdrop blur, with\n * the edge riding inside the prominent elevation. A plugin that hand-rolls this\n * is how tokens like --dsw-specific-menu get invented; use this instead. --- */\n& .dsh-ui-surface {\n --dsw-elevation-stroke-color: var(--dsw-alias-border-l1);\n --dsh-scrollbar-thumb: var(--dsw-alias-scrollbar-bg-l2);\n --dsh-scrollbar-thumb-hover: var(--dsw-alias-scrollbar-hover-l2);\n position: relative;\n display: flex;\n flex-direction: column;\n border: 0;\n border-radius: var(--dsw-radius-lg);\n background: var(--dsw-menu-surface-fill);\n backdrop-filter: var(--dsw-menu-backdrop-filter);\n box-shadow: var(--dsw-elevation-prominent);\n color: var(--dsw-alias-label-primary);\n font-size: 13px;\n line-height: 20px;\n min-width: 0;\n}\n& .dsh-ui-surface-body { display: flex; flex-direction: column; gap: 8px; padding: 12px 14px 14px; overflow-y: auto; }\n& .dsh-ui-surface-head { display: flex; align-items: center; gap: 8px; min-width: 0; }\n& .dsh-ui-surface-title { font-size: 14px; line-height: 22px; font-weight: 500; color: var(--dsw-alias-label-primary); }\n\n/* --- Native select. The primitives ship no select, so a plugin that offers a\n * closed list of choices keeps the platform control and matches the official\n * settings field geometry exactly (34px, 0.5px l4, radius-md, layer-3). A\n * SegmentedControl is the primitive to reach for when the choices are few\n * enough to show at once. --- */\n& .dsh-ui-select {\n box-sizing: border-box;\n width: 100%;\n min-width: 0;\n height: 34px;\n padding: 0 12px;\n border: 0.5px solid var(--dsw-alias-border-l4);\n border-radius: var(--dsw-radius-md);\n background: var(--dsw-alias-bg-layer-3);\n font: inherit;\n font-size: 13px;\n line-height: 1.5;\n color: var(--dsw-alias-label-primary);\n cursor: pointer;\n}\n& .dsh-ui-select:focus-visible { outline: none; border-color: var(--dsw-alias-state-business-primary); }\n& .dsh-ui-select:disabled { color: var(--dsw-alias-label-tertiary); cursor: default; }\n& .dsh-ui-select[aria-invalid='true'] { border-color: var(--dsw-alias-state-error-primary); }\n\n/* Long panels scroll inside themselves instead of growing the host page. */\n& .dsh-ui-panel { display: flex; flex-direction: column; gap: 16px; min-width: 0; }\n& .dsh-ui-panel-wide { max-width: 100%; }\n\n@media (prefers-reduced-motion: reduce) {\n & *, & *::before, & *::after { transition-duration: 0.01ms !important; animation-duration: 0.01ms !important; }\n}\n}\n`\n // Widen every recipe from \"a descendant of the root\" to \"the root, or one of\n // its descendants\". Written as a transform rather than by hand so no recipe\n // can be added later with only the descendant form. The pattern is narrow on\n // purpose: a leading `&` followed by one recipe class and no combinator, so\n // sibling and child rules such as `.dsh-ui-field + .dsh-ui-field` keep their\n // own meaning and are left alone.\n return sheet.replace(/^& (\\.dsh-ui-[a-z0-9-]+)(?![+>~])/gm, (_match, className: string) =>\n `&${className}, & ${className}`)\n}\n","/** Recap-owned records. Shared TaskCheckpoint / RPC / slot names come from @klarkxy/dsh-plugin-kit/contracts. */\nimport type {\n EvidenceRef,\n ProducerMessageSource,\n RpcResult,\n TaskCheckpoint,\n TaskContract,\n} from '@klarkxy/dsh-plugin-kit/contracts'\n\nexport type {\n EvidenceRef,\n ProducerMessageSource,\n RpcResult,\n TaskCheckpoint,\n TaskContract,\n}\n\nexport { CHAT_EVENTS_SLOT } from '@klarkxy/dsh-plugin-kit/contracts'\n\n/** DSH message source identity for this plugin's own messages. */\nexport const RECAP_PLUGIN = '@klarkxy/dsh-recap'\nexport const RECAP_SOURCE_KIND = 'plugin:@klarkxy/dsh-recap' as const\nexport const RECAP_RPC_CHANNEL = '/dsh-recap'\nexport const RECAP_DISPLAY_PURPOSE = 'recap.display'\nexport const RECAP_CHECKPOINT_PURPOSE = 'recap.checkpoint'\nexport const DEFAULT_IDLE_RETURN_MS = 15 * 60 * 1000\nexport const MAX_LOG_EVENTS = 256\nexport const MAX_EXCERPT_CHARS = 200\nexport const MAX_CARD_BODY_CHARS = 4000\nexport const MAX_CHECKPOINT_CHARS = 2000\nexport const LONG_TASK_MIN_MS = 60_000\nexport const LONG_TASK_MIN_STEPS = 2\nexport const LONG_TASK_MIN_TOOLS = 3\nexport const MEANINGFUL_TOOL_DELTA = 3\n\nexport type RecapSourceStatus = 'completed' | 'failed' | 'cancelled' | 'running'\nexport type RecapTrigger = 'turn-end' | 'idle-return' | 'retry' | 'manual'\nexport type RecapCardKind = 'deterministic' | 'generated' | 'cached'\nexport type RecapGeneration = 'idle' | 'running' | 'failed' | 'cancelled' | 'superseded'\n\n/** Plugin-page model selection. Empty provider/model means \"follow the default\". */\nexport interface RecapModelRoute {\n readonly provider: string\n readonly model: string\n readonly reasoningEffort?: string\n}\n\nexport interface RecapSettings {\n revision: number\n cardsEnabled: boolean\n checkpointsEnabled: boolean\n semanticCheckpointsEnabled: boolean\n idleReturnMs: number\n /** Model for recap cards (display) and semantic checkpoints, chosen on the plugin page. */\n displayModel: RecapModelRoute\n checkpointModel: RecapModelRoute\n}\n\nexport const defaultModelRoute = (): RecapModelRoute => ({ provider: '', model: '' })\n\nexport const defaultSettings = (): RecapSettings => ({\n revision: 0,\n cardsEnabled: true,\n checkpointsEnabled: true,\n semanticCheckpointsEnabled: true,\n idleReturnMs: DEFAULT_IDLE_RETURN_MS,\n displayModel: defaultModelRoute(),\n checkpointModel: defaultModelRoute(),\n})\n\nexport interface RecapCard {\n id: string\n sessionId: string\n sourceVersion: string\n fromSeq: number\n toSeq: number\n trigger: RecapTrigger\n sourceStatus: Exclude\n title: string\n body: string\n kind: RecapCardKind\n generation: RecapGeneration\n receiptId?: string\n createdAt: number\n updatedAt: number\n}\n\nexport interface RecapPersistedState {\n settings: RecapSettings\n cards: RecapCard[]\n checkpoints: TaskCheckpoint[]\n}\n\nexport interface RecapStore {\n load(): RecapPersistedState\n save(state: RecapPersistedState): Promise\n}\n\nexport interface RecapStatus {\n settings: RecapSettings\n cards: RecapCard[]\n checkpoints: TaskCheckpoint[]\n storageFailed: boolean\n}\n\nexport interface RecapLogEvent {\n seq: number\n type: string\n time: number\n data: unknown\n}\n\nexport interface RecapToolFact {\n name: string\n callId?: string\n proposedChange: boolean\n error?: boolean\n seq: number\n outcome: 'verified' | 'failed' | 'unverified' | 'missing' | 'cancelled' | 'unknown'\n}\n\nexport interface RecapFacts {\n sessionId: string\n fromSeq: number\n toSeq: number\n sourceVersion: string\n sourceStatus: RecapSourceStatus\n turn?: number\n stepCount: number\n userTurns: number\n toolCalls: number\n toolResults: number\n proposals: number\n durationMs: number\n lastUserExcerpt?: string\n tools: RecapToolFact[]\n constraints: string[]\n}\n\nexport type MoodContractApi = {\n getContract?(sessionId: string): TaskContract | undefined\n}\n\nexport function fail(code: string, message: string): RpcResult {\n return { ok: false, error: { code, message } }\n}\n\nexport function ok(value: T): RpcResult {\n return { ok: true, value }\n}\n\nexport function recapSourceVersion(sessionId: string, toSeq: number): string {\n return `${sessionId}#${toSeq}`\n}\n\nexport function parseSessionId(payload: unknown): string | undefined {\n if (!payload || typeof payload !== 'object' || Array.isArray(payload)) return undefined\n const sessionId = (payload as { sessionId?: unknown }).sessionId\n return typeof sessionId === 'string' && sessionId.length > 0 && sessionId.length <= 200 ? sessionId : undefined\n}\n","export const USER_ACTIVITY_KINDS = ['pointer', 'keydown', 'focus', 'visible'] as const\nexport type UserActivityKind = (typeof USER_ACTIVITY_KINDS)[number]\n\nexport function isUserActivity(kind: string): kind is UserActivityKind {\n return (USER_ACTIVITY_KINDS as readonly string[]).includes(kind)\n}\n\nexport function shouldRequestIdleReturn(input: {\n now: number\n lastUserActivityAt: number\n idleReturnMs: number\n cardsEnabled: boolean\n visible: boolean\n hidden?: boolean\n focused?: boolean\n assistantStreaming?: boolean\n}): boolean {\n if (!input.cardsEnabled || input.hidden || !input.visible) return false\n if (input.focused === false) return false\n if (input.assistantStreaming) return false\n return input.now - input.lastUserActivityAt >= input.idleReturnMs\n}\n\nexport function nextActivityTimestamp(kind: string, previous: number, now: number): number {\n return isUserActivity(kind) ? now : previous\n}\n\nexport function shouldSkipRecapAutoRefresh(input: {\n busy: boolean\n editing?: boolean\n disposed?: boolean\n}): boolean {\n return input.busy || input.editing === true || input.disposed === true\n}\n\nexport function createRecapClientWork() {\n let generation = 0\n let request = 0\n let disposed = false\n return {\n get disposed() { return disposed },\n beginLoad() {\n generation += 1\n request += 1\n return generation\n },\n beginRequest() {\n request += 1\n return { generation, request }\n },\n snapshot() {\n return { generation, request }\n },\n isLoad(generationToken: number) {\n return !disposed && generation === generationToken\n },\n isRequest(token: { generation: number; request: number }) {\n return !disposed && generation === token.generation && request === token.request\n },\n dispose() {\n disposed = true\n generation += 1\n request += 1\n },\n }\n}\n\nexport type RecapClientWork = ReturnType\n\nexport function isCurrentRecapRequest(input: {\n mounted: boolean\n disposed?: boolean\n sessionId: string\n viewSessionId: string\n requestId: number\n latestRequestId: number\n generation?: number\n viewGeneration?: number\n}): boolean {\n if (!input.mounted || input.disposed) return false\n if (input.sessionId !== input.viewSessionId) return false\n if (input.requestId !== input.latestRequestId) return false\n if (input.generation !== undefined && input.generation !== input.viewGeneration) return false\n return true\n}\n","import type { Context } from '@deepseek-ai/cordis'\nimport { CHAT_EVENTS_SLOT } from '@klarkxy/dsh-plugin-kit/contracts'\nimport { useFeatureRefresh, useNativeSeat, type NativeSurfaceClient } from '@klarkxy/dsh-plugin-kit/client-utils'\nimport {\n modelMenuChoiceKey, modelMenuEffortOptions, parseModelMenuChoiceKey, parseModelMenuChoices, type ModelMenuChoice,\n} from '@klarkxy/dsh-plugin-kit/model-menu'\nimport { useEffect, useId, useRef, useState } from 'react'\nimport { Button, Input, StateDot, Switch } from '@deepseek-ai/dsh-client-ui-primitives'\nimport { officialUiCss } from '@klarkxy/dsh-plugin-kit/official-ui'\nimport {\n RECAP_PLUGIN, RECAP_RPC_CHANNEL, defaultSettings,\n type RecapCard, type RecapModelRoute, type RecapSettings, type RecapStatus, type RpcResult,\n} from './contracts.ts'\nimport {\n createRecapClientWork, shouldRequestIdleReturn, shouldSkipRecapAutoRefresh, type RecapClientWork,\n} from './idle.ts'\n\nexport const name = 'dsh-recap-client'\nexport const inject = ['slots', 'connection', 'remote', 'remote.session', 'sessions', 'locale', 'uiWorkspace', 'uiSession'] as const\nexport {\n createRecapClientWork, isCurrentRecapRequest, shouldRequestIdleReturn, shouldSkipRecapAutoRefresh,\n nextActivityTimestamp,\n} from './idle.ts'\nexport { CHAT_EVENTS_SLOT }\n\ntype RpcCaller = { call(channel: string, endpoint: string, payload: unknown): Promise }\ntype SlotHandle = {\n inject(key: string, callback: () => unknown): () => void\n register(spec: { name: string; id: string; label: string; order: number } | { name: string; key: string }, render: unknown): () => void\n}\ntype RecapClient = Context & NativeSurfaceClient & {\n connection: { rpc: RpcCaller; generation?: { subscribe(listener: () => void): () => void } }\n remote?: { session?: { modelCatalog?: () => Promise } }\n slots: SlotHandle\n}\n\nexport function recapHasRunningGeneration(cards: readonly RecapCard[]): boolean {\n return cards.some(card => card.generation === 'running')\n}\n\nexport function recapSeatProps(props: unknown): { sessionId: string; locale?: string; hidden: boolean } | undefined {\n if (!props || typeof props !== 'object' || Array.isArray(props)) return undefined\n const record = props as Record\n const nested = record.owner && typeof record.owner === 'object' ? record.owner as Record : undefined\n const sessionId = typeof record.sessionId === 'string' ? record.sessionId : typeof nested?.sessionId === 'string' ? nested.sessionId : undefined\n if (!sessionId) return undefined\n const locale = typeof record.locale === 'string' ? record.locale : typeof nested?.locale === 'string' ? nested.locale : undefined\n const hidden = record.hidden === true || nested?.hidden === true\n return locale ? { sessionId, locale, hidden } : { sessionId, hidden }\n}\n\nexport function recapCardKey(seat: { sessionId: string; locale?: string }): string {\n return `${seat.sessionId}:${seat.locale ?? ''}`\n}\n\nfunction unwrap(result: RpcResult): T {\n if (!result.ok) throw new Error(result.error.message)\n return result.value\n}\n\nexport async function recapCall(rpc: RpcCaller, endpoint: string, payload: unknown = {}): Promise {\n return unwrap(await rpc.call(RECAP_RPC_CHANNEL, endpoint, payload) as RpcResult)\n}\n\nfunction copy(locale: string | undefined, zh: string, en: string): string {\n return locale === 'en' ? en : zh\n}\n\nexport async function runRecapStatusLoad(input: {\n rpc: RpcCaller\n sessionId?: string\n isCurrent: () => boolean\n failedMessage: string\n onStatus: (status: RecapStatus) => void\n onError: (message: string) => void\n}): Promise {\n try {\n const status = await recapCall(input.rpc, 'status', input.sessionId ? { sessionId: input.sessionId } : {})\n if (!input.isCurrent()) return\n input.onStatus(status)\n } catch (cause) {\n if (!input.isCurrent()) return\n input.onError(cause instanceof Error && cause.message ? cause.message : input.failedMessage)\n }\n}\n\n/** Recap's single user-facing name, shared by the chat seat label and copy. */\nexport function recapTitle(locale: string | undefined): string {\n return copy(locale, '回顾', 'Recap')\n}\n\n/** Maps every generation outcome to a dot state instead of reading anything non-running as done. */\nexport function recapGenerationDot(generation: RecapCard['generation']): 'ongoing' | 'error' | 'warning' | 'idle' | 'done' {\n switch (generation) {\n case 'running': return 'ongoing'\n case 'failed': return 'error'\n case 'cancelled': return 'warning'\n case 'superseded': return 'idle'\n default: return 'done'\n }\n}\n\nexport function recapGenerationLabel(generation: RecapCard['generation'], locale: string | undefined): string {\n switch (generation) {\n case 'running': return copy(locale, '生成中', 'Generating')\n case 'failed': return copy(locale, '生成失败', 'Failed')\n case 'cancelled': return copy(locale, '已取消', 'Cancelled')\n case 'superseded': return copy(locale, '已被新回顾替代', 'Superseded')\n default: return copy(locale, '已完成', 'Done')\n }\n}\n\n/**\n * The chat seat stays a quiet lifecycle controller until there is something to\n * show: stored cards or a generation in flight. Only then does it render the card UI.\n */\nexport function recapCardVisible(input: { hidden?: boolean; cards: readonly RecapCard[] }): boolean {\n // A running generation always belongs to a stored card, so \"has cards\" covers both cases.\n return !input.hidden && input.cards.length > 0\n}\n\nexport async function runRecapAct(input: {\n rpc: RpcCaller\n sessionId: string\n endpoint: 'cancel' | 'retry' | 'refresh'\n cardId?: string\n isCurrent: () => boolean\n failedMessage: string\n onBusy: (busy: boolean) => void\n onStatus: (status: RecapStatus) => void\n onError: (message: string) => void\n}): Promise {\n if (!input.isCurrent()) return\n input.onBusy(true)\n try {\n const payload = input.endpoint === 'refresh'\n ? { sessionId: input.sessionId }\n : { cardId: input.cardId, sessionId: input.sessionId }\n await recapCall(input.rpc, input.endpoint, payload)\n if (!input.isCurrent()) return\n const status = await recapCall(input.rpc, 'status', { sessionId: input.sessionId })\n if (!input.isCurrent()) return\n input.onStatus(status)\n } catch (cause) {\n if (!input.isCurrent()) return\n input.onError(cause instanceof Error ? cause.message : input.failedMessage)\n } finally {\n if (!input.isCurrent()) return\n input.onBusy(false)\n }\n}\n\nexport async function runRecapIdleReturn(input: {\n rpc: RpcCaller\n sessionId: string\n isCurrent: () => boolean\n failedMessage: string\n onStatus: (status: RecapStatus) => void\n onError: (message: string) => void\n onActivity: () => void\n}): Promise {\n if (!input.isCurrent()) return\n try {\n await recapCall(input.rpc, 'idle.return', { sessionId: input.sessionId })\n if (!input.isCurrent()) return\n const status = await recapCall(input.rpc, 'status', { sessionId: input.sessionId })\n if (!input.isCurrent()) return\n input.onActivity()\n input.onStatus(status)\n } catch {\n if (!input.isCurrent()) return\n input.onError(input.failedMessage)\n }\n}\n\nconst css = `${officialUiCss(['dsh-recap-card', 'dsh-recap-settings'])}\n/* The two surfaces take their measure and rhythm from the contract; what stays\n * here is the native
header the primitives do not cover, and the\n * generated body, which is prose rather than the monospaced code block the\n * contract's own code well is for. */\n.dsh-recap-card, .dsh-recap-settings { max-width: 760px; }\n.dsh-recap-sr {\n position: absolute; width: 1px; height: 1px; padding: 0; margin: -1px;\n overflow: hidden; clip: rect(0 0 0 0); white-space: nowrap; border: 0;\n}\n.dsh-recap-summary { display: flex; align-items: center; gap: 8px; min-width: 0; cursor: pointer; }\n.dsh-recap-body {\n margin: 0;\n font: inherit;\n white-space: pre-wrap;\n overflow-wrap: anywhere;\n color: var(--dsw-alias-label-secondary);\n}\n`\n\n/** Retry; when it would overwrite a finished recap, a second click within 3s confirms. */\nfunction RetryButton(props: { locale?: string; disabled?: boolean; confirm: boolean; onRetry(): void }) {\n const [armed, setArmed] = useState(false)\n const timer = useRef>(undefined)\n useEffect(() => () => clearTimeout(timer.current), [])\n const disarm = () => { clearTimeout(timer.current); setArmed(false) }\n const confirmLabel = copy(props.locale, '确认覆盖？', 'Confirm replace?')\n return <>\n \n {armed ? confirmLabel : ''}\n \n}\n\nexport function RecapEventsCard({\n client, sessionId, locale, hidden, idle = true, quiet = false,\n}: {\n client: RecapClient\n sessionId: string\n locale?: string\n hidden?: boolean\n idle?: boolean\n quiet?: boolean\n}) {\n const rpc = client.connection.rpc\n const [cards, setCards] = useState([])\n const [error, setError] = useState('')\n const [cardsOn, setCardsOn] = useState(true)\n const [busy, setBusy] = useState(false)\n const lastActivityAt = useRef(Date.now())\n const idleMs = useRef(defaultSettings().idleReturnMs)\n const cardsEnabled = useRef(true)\n const busyRef = useRef(false)\n const workRef = useRef(undefined)\n if (!workRef.current) workRef.current = createRecapClientWork()\n const work = workRef.current\n\n function markBusy(value: boolean) {\n busyRef.current = value\n setBusy(value)\n }\n\n function applyStatus(status: RecapStatus) {\n idleMs.current = status.settings.idleReturnMs\n cardsEnabled.current = status.settings.cardsEnabled\n setCardsOn(status.settings.cardsEnabled)\n setCards(status.cards)\n setError('')\n }\n\n useEffect(() => () => { work.dispose() }, [work])\n\n useEffect(() => {\n const generation = work.beginLoad()\n lastActivityAt.current = Date.now()\n busyRef.current = false\n setBusy(false)\n setError('')\n setCards([])\n void runRecapStatusLoad({\n rpc,\n sessionId,\n isCurrent: () => work.isLoad(generation),\n failedMessage: copy(locale, '无法读取回顾。', 'Could not load recap.'),\n onStatus: applyStatus,\n onError: setError,\n })\n return () => { if (work.isLoad(generation)) work.beginLoad() }\n }, [rpc, sessionId, locale, work])\n\n useEffect(() => {\n if (hidden || !idle || typeof document === 'undefined') return undefined\n const requestIdle = () => {\n const token = work.beginRequest()\n void runRecapIdleReturn({\n rpc,\n sessionId,\n isCurrent: () => work.isRequest(token),\n failedMessage: copy(locale, '闲置回顾失败。', 'Idle recap failed.'),\n onStatus: applyStatus,\n onError: setError,\n onActivity: () => { lastActivityAt.current = Date.now() },\n })\n }\n const maybeIdleReturn = () => {\n if (!shouldRequestIdleReturn({\n now: Date.now(),\n lastUserActivityAt: lastActivityAt.current,\n idleReturnMs: idleMs.current,\n cardsEnabled: cardsEnabled.current,\n visible: document.visibilityState === 'visible',\n hidden: false,\n focused: document.hasFocus(),\n })) return\n requestIdle()\n }\n const onPointer = () => { lastActivityAt.current = Date.now() }\n const onKey = () => { lastActivityAt.current = Date.now() }\n document.addEventListener('pointerdown', onPointer)\n document.addEventListener('keydown', onKey)\n window.addEventListener('focus', maybeIdleReturn)\n document.addEventListener('visibilitychange', maybeIdleReturn)\n return () => {\n document.removeEventListener('pointerdown', onPointer)\n document.removeEventListener('keydown', onKey)\n window.removeEventListener('focus', maybeIdleReturn)\n document.removeEventListener('visibilitychange', maybeIdleReturn)\n }\n }, [rpc, sessionId, locale, hidden, idle, work])\n\n function refreshCards() {\n if (shouldSkipRecapAutoRefresh({ busy: busyRef.current, disposed: work.disposed })) return\n const token = work.snapshot()\n void runRecapStatusLoad({\n rpc,\n sessionId,\n isCurrent: () => work.isRequest(token) && !busyRef.current,\n failedMessage: copy(locale, '无法读取回顾。', 'Could not load recap.'),\n onStatus: applyStatus,\n onError: setError,\n })\n }\n\n useFeatureRefresh(\n client,\n sessionId,\n refreshCards,\n recapHasRunningGeneration(cards),\n Boolean(sessionId) && hidden !== true,\n )\n\n function act(endpoint: 'cancel' | 'retry' | 'refresh', cardId?: string) {\n const token = work.beginRequest()\n void runRecapAct({\n rpc,\n sessionId,\n endpoint,\n cardId,\n isCurrent: () => work.isRequest(token),\n failedMessage: copy(locale, '操作失败。', 'Action failed.'),\n onBusy: markBusy,\n onStatus: applyStatus,\n onError: setError,\n })\n }\n\n // `quiet` keeps the seat a background controller: nothing renders until there is a card to show.\n if (quiet ? !recapCardVisible({ hidden, cards }) : hidden) return null\n if (!cardsOn && cards.length === 0 && !error) return null\n const running = recapHasRunningGeneration(cards)\n return
\n {error ?

{error}

: null}\n {cardsOn ?
\n \n {running ? copy(locale, '正在生成回顾…', 'Generating recap…') : ''}\n
: null}\n {cards.map(card => (\n
\n \n \n {card.title}\n {recapGenerationLabel(card.generation, locale)}\n \n 
{card.body}
\n
\n {card.generation === 'running'\n ? \n : act('retry', card.id)} />}\n
\n
\n ))}\n
\n}\n\nfunction RecapBackgroundSeat({ client, ...props }: { client: RecapClient } & Record) {\n const seat = useNativeSeat(client, props)\n if (!seat.sessionId) return null\n return