clash-verge-rev-lite/src/services/global-log-service.ts

// 全局日志服务，使应用在任何页面都能收集日志
import { create } from "zustand";
import { createAuthSockette } from "@/utils/websocket";
import dayjs from "dayjs";

// 最大日志数量
const MAX_LOG_NUM = 1000;

export type LogLevel = "warning" | "info" | "debug" | "error" | "all";

export interface ILogItem {
  time?: string;
  type: string;
  payload: string;
  [key: string]: any;
}

interface GlobalLogStore {
  logs: ILogItem[];
  enabled: boolean;
  isConnected: boolean;
  currentLevel: LogLevel;
  setEnabled: (enabled: boolean) => void;
  setCurrentLevel: (level: LogLevel) => void;
  clearLogs: () => void;
  appendLog: (log: ILogItem) => void;
}

// 创建全局状态存储
export const useGlobalLogStore = create<GlobalLogStore>((set) => ({
  logs: [],
  enabled: false,
  isConnected: false,
  currentLevel: "info",
  setEnabled: (enabled) => set({ enabled }),
  setCurrentLevel: (currentLevel) => set({ currentLevel }),
  clearLogs: () => set({ logs: [] }),
  appendLog: (log: ILogItem) =>
    set((state) => {
      const newLogs =
        state.logs.length >= MAX_LOG_NUM
          ? [...state.logs.slice(1), log]
          : [...state.logs, log];
      return { logs: newLogs };
    }),
}));

// 构建WebSocket URL
const buildWSUrl = (server: string, logLevel: LogLevel) => {
  let baseUrl = `${server}/logs`;

  // 只处理日志级别参数
  if (logLevel && logLevel !== "info") {
    const level = logLevel === "all" ? "debug" : logLevel;
    baseUrl += `?level=${level}`;
  }

  return baseUrl;
};

// 初始化全局日志服务
let globalLogSocket: any = null;

export const initGlobalLogService = (
  server: string,
  secret: string,
  enabled: boolean = false,
  logLevel: LogLevel = "info",
) => {
  const { appendLog, setEnabled } = useGlobalLogStore.getState();

  // 更新启用状态
  setEnabled(enabled);

  // 如果不启用或没有服务器信息，则不初始化
  if (!enabled || !server) {
    closeGlobalLogConnection();
    return;
  }

  // 关闭现有连接
  closeGlobalLogConnection();

  // 创建新的WebSocket连接，使用新的认证方法
  const wsUrl = buildWSUrl(server, logLevel);
  console.log(`[GlobalLog] Connecting to log service: ${wsUrl}`);

  if (!server) {
    console.warn("[GlobalLog] Server URL is empty, cannot establish connection");
    return;
  }

  globalLogSocket = createAuthSockette(wsUrl, secret, {
    timeout: 8000, // 8秒超时
    onmessage(event) {
      try {
        const data = JSON.parse(event.data) as ILogItem;
        const time = dayjs().format("MM-DD HH:mm:ss");
        appendLog({ ...data, time });
      } catch (error) {
        console.error("[GlobalLog] Failed to parse log data:", error);
      }
    },
    onerror(event) {
      console.error("[GlobalLog] WebSocket connection error", event);

      // 记录错误状态但不关闭连接，让重连机制起作用
      useGlobalLogStore.setState({ isConnected: false });

      // 只有在重试彻底失败后才关闭连接
      if (
        event &&
        typeof event === "object" &&
        "type" in event &&
        event.type === "error"
      ) {
        console.error("[GlobalLog] Connection exhausted retries, closing");
        closeGlobalLogConnection();
      }
    },
    onclose(event) {
      console.log("[GlobalLog] WebSocket connection closed", event);
      useGlobalLogStore.setState({ isConnected: false });
    },
    onopen(event) {
      console.log("[GlobalLog] WebSocket connection established", event);
      useGlobalLogStore.setState({ isConnected: true });
    },
  });
};

// 关闭全局日志连接
export const closeGlobalLogConnection = () => {
  if (globalLogSocket) {
    globalLogSocket.close();
    globalLogSocket = null;
    useGlobalLogStore.setState({ isConnected: false });
  }
};

// 切换日志级别
export const changeLogLevel = (
  level: LogLevel,
  server: string,
  secret: string,
) => {
  const { enabled } = useGlobalLogStore.getState();
  useGlobalLogStore.setState({ currentLevel: level });

  if (enabled && server) {
    initGlobalLogService(server, secret, enabled, level);
  }
};

// 切换启用状态
export const toggleLogEnabled = (server: string, secret: string) => {
  const { enabled, currentLevel } = useGlobalLogStore.getState();
  const newEnabled = !enabled;

  useGlobalLogStore.setState({ enabled: newEnabled });

  if (newEnabled && server) {
    initGlobalLogService(server, secret, newEnabled, currentLevel);
  } else {
    closeGlobalLogConnection();
  }
};

// 获取日志清理函数
export const clearGlobalLogs = () => {
  useGlobalLogStore.getState().clearLogs();
};

// 自定义钩子，用于获取过滤后的日志数据
export const useGlobalLogData = (logLevel: LogLevel = "all") => {
  const logs = useGlobalLogStore((state) => state.logs);

  // 根据当前选择的日志等级过滤日志
  if (logLevel === "all") {
    return logs;
  } else {
    return logs.filter((log) => log.type.toLowerCase() === logLevel);
  }
};