/**
 * Store 状态形状（core/types.ts 扩展）
 */
export interface ScreenState {
  /** 最新快照（最新值语义） */
  latest: PanelSnapshot | null;
  /** 各设备温度滚动窗口（流式语义）：deviceId → 定长序列 */
  tempWindows: Map<string, { ts: number; v: number }[]>;
  /** 告警列表（事件语义，最新在前，上限 50） */
  alarms: AlarmRecord[];
  /** 连接状态 */
  connState: "connecting" | "open" | "reconnecting" | "closed";
}

export interface AlarmRecord {
  id: string;          // 服务器生成，去重依据
  ts: number;
  deviceId: string;
  deviceName: string;
  message: string;
  level: "warn" | "danger";
}

import type { PanelSnapshot, AlarmRecord, ScreenState, DataSource } from "../types";

/** 订阅者声明：要什么数据 + 什么频率 */
export interface ScreenSubscription {
  /** 最新快照（频率：minIntervalMs 毫秒最多一次） */
  onSnapshot?: (snap: PanelSnapshot) => void;
  /** 温度窗口变化（曲线类屏幕用，每帧推送） */
  onWindow?: (windows: ScreenState["tempWindows"]) => void;
  /** 告警列表变化 */
  onAlarms?: (alarms: AlarmRecord[]) => void;
  /** 连接状态变化 */
  onConnState?: (s: ScreenState["connState"]) => void;
  /** 快照最小推送间隔（默认 1000ms） */
  minIntervalMs?: number;
}

const WINDOW_SIZE = 120;      // 温度窗口：120 点
const ALARM_LIMIT = 50;       // 告警上限

/**
 * 全局数据中枢：唯一持有状态、唯一连接数据源
 * 三屏及所有组件只能通过 subscribe 领数据
 */
export class ScreenStore {
  private state: ScreenState = {
    latest: null,
    tempWindows: new Map(),
    alarms: [],
    connState: "closed",
  };
  private subs: { fn: ScreenSubscription; lastPush: number }[] = [];
  private source: DataSource | null = null;

  // ===== 生命周期 =====

  /** 绑定数据源并启动（全应用只调用一次） */
  attach(source: DataSource): void {
    this.source = source;
    source.subscribe((snap) => this.ingest(snap));
    // WsDataSource 的扩展能力：连接状态（Day 63 的 onState）
    (source as { onState?: (s: ScreenState["connState"]) => void }).onState?.(
      (s) => this.setConnState(s)
    );
    source.start();
  }

  stop(): void {
    this.source?.stop();
    this.source = null;
  }

  // ===== 订阅 API =====

  /**
   * 订阅数据（返回退订函数）
   * 新订阅者立即收到当前状态快照（"回答现在"——见第四节）
   */
  subscribe(sub: ScreenSubscription): () => void {
    const entry = { fn: sub, lastPush: 0 };
    this.subs.push(entry);
    // 立即回答：新订阅者马上拿到已有状态
    if (this.state.latest && sub.onSnapshot) sub.onSnapshot(this.state.latest);
    if (sub.onConnState) sub.onConnState(this.state.connState);
    if (sub.onAlarms) sub.onAlarms(this.state.alarms);
    if (sub.onWindow) sub.onWindow(this.state.tempWindows);
    return () => { this.subs = this.subs.filter((s) => s !== entry); };
  }

  // ===== 数据摄入 =====

  /** 快照到达：更新三类状态 + 分发 */
  private ingest(snap: PanelSnapshot): void {
    this.state = {
      ...this.state,
      latest: snap,
      tempWindows: this.pushWindows(snap),
    };
    this.dispatch();
  }

  /** 告警到达（服务器独立通道或快照内嵌） */
  ingestAlarm(alarm: AlarmRecord): void {
    // 事件语义：按 id 去重（QoS1 思想的业务层落地，Day 60/61 同款）
    if (this.state.alarms.some((a) => a.id === alarm.id)) return;
    this.state.alarms = [alarm, ...this.state.alarms].slice(0, ALARM_LIMIT);
    this.subs.forEach(({ fn }) => fn.onAlarms?.(this.state.alarms));
  }

  private setConnState(s: ScreenState["connState"]): void {
    this.state = { ...this.state, connState: s };
    this.subs.forEach(({ fn }) => fn.onConnState?.(s));
  }

  /** 温度窗口维护（定长滚动，Day 56 同款） */
  private pushWindows(snap: PanelSnapshot): Map<string, { ts: number; v: number }[]> {
    const windows = new Map(this.state.tempWindows);
    for (const d of snap.devices) {
      const buf = windows.get(d.deviceId) ?? [];
      buf.push({ ts: snap.ts, v: d.temperature });
      if (buf.length > WINDOW_SIZE) buf.shift();
      windows.set(d.deviceId, buf);
    }
    return windows;
  }

  // ===== 分发（含分频） =====

  private dispatch(): void {
    const now = performance.now();
    for (const entry of this.subs) {
      const { fn, lastPush } = entry;
      const interval = fn.minIntervalMs ?? 1000;
      // 快照：分频（订阅者声明的最小间隔）
      if (fn.onSnapshot && now - lastPush >= interval) {
        entry.lastPush = now;
        fn.onSnapshot(this.state.latest!);
      }
      // 窗口：曲线类每帧推（频率天然受 WS 推送节奏限制）
      fn.onWindow?.(this.state.tempWindows);
    }
  }
}

轮播切屏的时间线（有/无"立即回答"对比）：
无：切屏 → 屏B激活订阅 → [最长1s空白] → 下次推送 → 数据上屏
有：切屏 → 屏B激活订阅 → 立即回放 latest → 数据上屏（同帧内完成）

/**
 * 屏幕模块的标准生命周期（Day 68/69 的迁移模板）
 */
export function createMonitorScreen(el: HTMLElement, store: ScreenStore): ScreenModule {
  let unsub: (() => void) | null = null;

  return {
    /** 路由激活时调用：订阅重数据 */
    activate() {
      unsub = store.subscribe({
        onSnapshot: (snap) => updateCharts(snap),     // minIntervalMs: 5000 可选
        onWindow: (windows) => updateCurve(windows),
        onConnState: (s) => statusLight.set(s),
      });
      resizeCharts();   // 容器从 opacity:0 回来，保险起见 resize（Day 52 坑 1）
    },
    /** 路由离开时调用：退订重数据（轻量订阅可保留） */
    deactivate() {
      unsub?.();
      unsub = null;
    },
  };
}

1. server 启动（Day 63 迁移版）
2. app.ts：store.attach(new WsDataSource()) + router 启动
3. 每个屏的占位模块订阅 Store：
   屏A：onSnapshot → 显示 KPI 数字（纯文本）
   屏B：onWindow → 显示曲线点数（console 即可）
   屏C：onConnState → 显示状态灯（Day 58 T3 的组件迁移到 components/）
4. 验收点：
   a. 杀服务器 → 三屏状态灯同时变黄（状态唯一性的证明）
   b. 重启 → 状态灯同时变绿
   c. 轮播切换时数据零空白（"立即回答"生效）