import type { ClientContext, ISessions } from '@deepseek-ai/dsh-client-runtime/client'
import { createScope } from '@deepseek-ai/dsh-client-runtime/client'
import type {} from '@deepseek-ai/dsh-client-ui-layout/client'
import type {} from '@deepseek-ai/dsh-client-ui-conversation/client'
import type {} from '@deepseek-ai/dsh-client-ui-input-trigger/client'
import type {} from '@deepseek-ai/dsh-client-ui-tool/client'
import { QingDocPanel } from './QingDocPanel.js'
import { QingWriteToolCard } from './QingWriteToolCard.js'
import {
  QingAnnotateToolCard,
  QingEditToolCard,
  QingFocusToolCard,
  QingListDocsToolCard,
  QingListMaterialsToolCard,
  QingReadMaterialToolCard,
  QingReadToolCard,
  QingReviewCommitToolCard,
} from './QingToolCard.js'
import { qingClientStore } from './store.js'
import {
  blockContainsId,
  insertSelectionReference,
  qingSelectionReferenceSource,
  resolveSelectionTitle,
  type PmBlockNode,
} from './selectionReference.js'
import {
  insertAnnotationReference,
  qingAnnotationReferenceSource,
  remintDraftReferences,
  removeOccurrenceFromDraft,
  replaceOccurrenceRef,
} from './annotationReference.js'
import { installChipPresentation, type InputState as ChipInputState } from './chipPresentation.js'
import { installSelectionBubbleDecor } from './selectionBubbleDecor.js'
import { markPanelOpenSource } from './telemetry.js'

export const name = 'dsh-qingagent-client'
export const inject = ['slots', 'layout', 'sessions', 'conversation', 'inputTriggers']

export function apply(ctx: ClientContext): void {
  // Cordis 的 get() 在类型上允许服务未就绪；本插件的 inject 已把三者声明为启动前置。
  const slots = ctx.get('slots')!
  const layout = ctx.get('layout')!
  const sessions = ctx.get('sessions') as unknown as ISessions
  const inputTriggers = ctx.get('inputTriggers')!

  // chip 提交必须能按 source 找回 codec；owner 缺失时 dsh 会阻止发送而不会降级成
  // clipboardText，因此 source 与选段 bridge 同属插件生命周期。
  ctx.effect(() => inputTriggers.registerSource(qingSelectionReferenceSource))
  // 批注采纳 chip 与选段 chip 同生命周期:codec 恒等展开完整修改指令。
  ctx.effect(() => inputTriggers.registerSource(qingAnnotationReferenceSource))
  // 发送气泡里的 [选段] 段落样式化(宿主消息渲染无槽位,DOM 装饰器随插件生命周期)。
  ctx.effect(() => installSelectionBubbleDecor())

  slots.inject('details', () => {
    let currentSessionId: string | undefined
    let disposePanel: (() => void) | undefined
    let releaseSession: (() => void) | undefined
    let unsubscribeStore: (() => void) | undefined
    let selectionScope: ReturnType<typeof createScope> | undefined
    let unsubscribeInput: (() => void) | undefined
    let selectionInsertInFlight = false

    const syncSelectionReference = () => {
      const sessionId = currentSessionId
      if (!sessionId || !selectionScope) return
      const snapshot = qingClientStore.getSnapshot(sessionId)
      const selection = snapshot.selection
      // 插入门:只响应用户显式 setSelection(fresh)。SSE 回声、loadState 重放的陈旧单槽
      // 一律不插——否则已被 ✕ 移除的选段会在下一次状态回灌时复活(评测 r1 席3 2.5)。
      if (!selection || snapshot.selectionFresh !== true) return
      // bail 同步发布 input state 会在插入返回前重入本函数;fresh 尚未消费,用进行中闸挡住。
      if (selectionInsertInFlight) return
      const title = resolveSelectionTitle(snapshot, selection.engineSessionId)

      // 「第 N 段」人类可读定位:引文多处相同时的消歧信息(拿不到块索引则省略)。
      // 选中列表项/表格等嵌套块时 blockId 不在顶层——递归下钻,按包含它的顶层块计序
      // (评测 r5 席3 实证:列表项选段丢失段号)。
      const panelPm = snapshot.panelEngineSessionId === selection.engineSessionId
        ? (snapshot.panelDoc as { pmDoc?: { content?: PmBlockNode[] } } | undefined)?.pmDoc
        : undefined
      const blockIndex = panelPm?.content?.findIndex(
        (block) => blockContainsId(block, selection.anchor.blockId)) ?? -1
      const paragraphOrdinal = blockIndex >= 0 ? blockIndex + 1 : undefined

      let inserted = false
      selectionInsertInFlight = true
      try {
        // 未移除时重复引用同一选段由 insertSelectionReference 的 occurrence 幂等挡住。
        inserted = insertSelectionReference(selectionScope.ctx, selection, title, paragraphOrdinal)
      } finally {
        selectionInsertInFlight = false
      }
      if (!inserted) {
        // adjudicating/submitting 等瞬态拒绝:保留 fresh 与 bridge selection,等下次发布重试。
        return
      }
      qingClientStore.consumeSelectionFresh(sessionId)

      // bridge selection 只是 ingress 单槽；成功铸成 composer occurrence 后立即清掉。
      // 这样用户删除原生 chip 就确实放弃该选段，后端动态提示也不会残留。
      void qingClientStore.clearSelection(sessionId).catch((error) => {
        console.warn('[qingagent] 清理已插入的选段 bridge 状态失败', error)
      })
    }

    const syncPanelRegistration = () => {
      const shouldRegister = currentSessionId !== undefined && qingClientStore.hasPanelContent(currentSessionId)
      if (shouldRegister && !disposePanel) {
        const shouldAutoOpen = currentSessionId !== undefined
          && qingClientStore.getSnapshot(currentSessionId).state?.engine.state !== 'online'
        if (shouldAutoOpen && currentSessionId) markPanelOpenSource(currentSessionId, 'auto')
        disposePanel = slots.register({
          name: 'details',
          priority: -10,
          inject: () => ({
            qingLayout: layout,
            // 审查按钮闭环:把组装好的审查 query 作为用户消息发进对应 dsh 会话(排队一轮)。
            qingSendMessage: async (dshSessionId: string, text: string) => {
              // conversation 是作用域寻址服务:sessions.scope() 返回的 AgentContext 挂在运行时
              // 根 fiber 下,不带本插件的 inject 声明会被 cordis 拒绝。用本插件 ctx 铸造同
              // 会话标签的临时作用域,属性链访问即携带 inject 与会话寻址。
              const handle = createScope(
                ctx as unknown as Parameters<typeof createScope>[0],
                dshSessionId as Parameters<typeof createScope>[1],
              )
              try {
                await (handle.ctx as unknown as { conversation: { send(text: string): Promise<void> } })
                  .conversation.send(text)
              } finally {
                handle.fiber.dispose()
              }
            },
            // 批注采纳:把完整修改指令铸成输入框 chip(不代发,发送权在用户)。
            qingInsertAnnotation: (instruction: string) => {
              const sessionId = currentSessionId
              if (!sessionId) return false
              const handle = createScope(
                ctx as unknown as Parameters<typeof createScope>[0],
                sessionId as Parameters<typeof createScope>[1],
              )
              try {
                return insertAnnotationReference(
                  handle.ctx as unknown as Parameters<typeof insertAnnotationReference>[0],
                  instruction,
                )
              } finally {
                handle.fiber.dispose()
              }
            },
          }),
        }, QingDocPanel)
        if (shouldAutoOpen) layout.openDetails()
      } else if (!shouldRegister && disposePanel) {
        disposePanel()
        disposePanel = undefined
      }
    }

    const syncCurrentSession = () => {
      const nextSessionId = sessions.list.getSnapshot().current
      if (nextSessionId === currentSessionId) return
      unsubscribeStore?.()
      unsubscribeInput?.()
      selectionScope?.fiber.dispose()
      releaseSession?.()
      disposePanel?.()
      unsubscribeStore = undefined
      unsubscribeInput = undefined
      selectionScope = undefined
      releaseSession = undefined
      disposePanel = undefined
      selectionInsertInFlight = false
      currentSessionId = nextSessionId === undefined ? undefined : String(nextSessionId)
      if (currentSessionId) {
        unsubscribeStore = qingClientStore.subscribe(currentSessionId, () => {
          syncPanelRegistration()
          syncSelectionReference()
        })
        releaseSession = qingClientStore.retain(currentSessionId)
        selectionScope = createScope(
          ctx as unknown as Parameters<typeof createScope>[0],
          currentSessionId as Parameters<typeof createScope>[1],
        )
        const inputFacade = selectionScope.ctx.conversation.input.for(selectionScope.ctx)
        const inputState = inputFacade.state
        const unsubscribeState = inputState.subscribe(syncSelectionReference)
        // 刷新恢复的草稿把未发送选段 chip 退化成了 [选段] 纯文本——检测并重铸(微任务防抖,幂等)。
        let remintQueued = false
        const scheduleRemint = () => {
          if (remintQueued) return
          remintQueued = true
          queueMicrotask(() => {
            remintQueued = false
            const scope = selectionScope
            if (!scope) return
            const snapshot = inputState.getSnapshot() as { draft?: string; phase?: string }
            if (snapshot.phase === 'plain'
              && (snapshot.draft?.includes('[选段]《') || /按批注修改[:\uFF1A]/u.test(snapshot.draft ?? ''))) {
              remintDraftReferences(scope.ctx)
            }
          })
        }
        const unsubscribeRemint = inputState.subscribe(scheduleRemint)
        scheduleRemint()
        // chip 呈现层:打标+药丸样式+hover 面板+移除角标(布局零影响,详见 chipPresentation)。
        const scopeCtx = selectionScope.ctx
        const uninstallChips = installChipPresentation({
          getInputState: () => inputState.getSnapshot() as unknown as ChipInputState | undefined,
          subscribeInputState: (listener) => inputState.subscribe(listener),
          removeOccurrence: (occurrenceId) => removeOccurrenceFromDraft(
            scopeCtx as unknown as Parameters<typeof removeOccurrenceFromDraft>[0],
            occurrenceId,
          ),
          replaceOccurrenceRef: (occurrenceId, newRef) => replaceOccurrenceRef(
            scopeCtx as unknown as Parameters<typeof replaceOccurrenceRef>[0],
            occurrenceId,
            newRef,
          ),
          onToast: (text) => {
            (inputFacade as unknown as { notify(level: 'info' | 'error', text: string): void })
              .notify('error', text)
          },
          getDocTitle: () => {
            const id = currentSessionId
            return id ? qingClientStore.getSnapshot(id).activeDoc?.title ?? undefined : undefined
          },
        })
        unsubscribeInput = () => {
          unsubscribeState()
          unsubscribeRemint()
          uninstallChips()
        }
      }
      syncPanelRegistration()
      syncSelectionReference()
    }

    const unsubscribeSessions = sessions.list.subscribe(syncCurrentSession)
    syncCurrentSession()
    return () => {
      unsubscribeSessions()
      unsubscribeStore?.()
      unsubscribeInput?.()
      selectionScope?.fiber.dispose()
      releaseSession?.()
      disposePanel?.()
    }
  })

  slots.inject('tool.call.toolview', () => slots.register({
    name: 'tool.call.toolview',
    key: 'qing_write_draft',
    inject: () => ({ qingLayout: layout }),
  }, QingWriteToolCard))

  // #23 具名状态卡:全部 qing 工具都有自己的名字与状态摘要,不落到通用卡。
  slots.inject('tool.call.toolview', () => slots.register({
    name: 'tool.call.toolview',
    key: 'qing_edit_draft',
    inject: () => ({ qingLayout: layout }),
  }, QingEditToolCard))
  slots.inject('tool.call.toolview', () => slots.register({
    name: 'tool.call.toolview',
    key: 'qing_review_commit',
    inject: () => ({ qingLayout: layout }),
  }, QingReviewCommitToolCard))
  slots.inject('tool.call.toolview', () => slots.register({
    name: 'tool.call.toolview',
    key: 'qing_annotate',
    inject: () => ({ qingLayout: layout }),
  }, QingAnnotateToolCard))
  slots.inject('tool.call.toolview', () => slots.register({
    name: 'tool.call.toolview',
    key: 'qing_read_draft',
    inject: () => ({ qingLayout: layout }),
  }, QingReadToolCard))
  slots.inject('tool.call.toolview', () => slots.register({
    name: 'tool.call.toolview',
    key: 'qing_list_materials',
    inject: () => ({ qingLayout: layout }),
  }, QingListMaterialsToolCard))
  slots.inject('tool.call.toolview', () => slots.register({
    name: 'tool.call.toolview',
    key: 'qing_read_material',
    inject: () => ({ qingLayout: layout }),
  }, QingReadMaterialToolCard))
  slots.inject('tool.call.toolview', () => slots.register({
    name: 'tool.call.toolview',
    key: 'qing_list_docs',
    inject: () => ({ qingLayout: layout }),
  }, QingListDocsToolCard))
  slots.inject('tool.call.toolview', () => slots.register({
    name: 'tool.call.toolview',
    key: 'qing_focus_doc',
    inject: () => ({ qingLayout: layout }),
  }, QingFocusToolCard))
}