NapCatQQ/packages/napcat-shell/napcat.ts

import { NCoreInitShell } from './base';
import { NapCatPathWrapper } from '@/napcat-common/src/path';
import { LogWrapper } from '@/napcat-core/helper/log';
import { connectToNamedPipe } from './pipe';
import { WebUiDataRuntime } from '@/napcat-webui-backend/src/helper/Data';
import { createProcessManager, type IProcessManager, type IWorkerProcess } from './process-api';
import path from 'path';
import { fileURLToPath } from 'url';

// ES 模块中获取 __dirname
const __filename = fileURLToPath(import.meta.url);
const __dirname = path.dirname(__filename);

// 环境变量配置
const ENV = {
  isWorkerProcess: process.env['NAPCAT_WORKER_PROCESS'] === '1',
  isMultiProcessDisabled: process.env['NAPCAT_DISABLE_MULTI_PROCESS'] === '1',
  isPipeDisabled: process.env['NAPCAT_DISABLE_PIPE'] === '1',
} as const;

// 初始化日志
const pathWrapper = new NapCatPathWrapper();
const logger = new LogWrapper(pathWrapper.logsPath);

// 进程管理器和当前 Worker 进程引用
let processManager: IProcessManager | null = null;
let currentWorker: IWorkerProcess | null = null;
let isElectron = false;

/**
 * 获取进程类型名称（用于日志）
 */
function getProcessTypeName (): string {
  return isElectron ? 'UtilityProcess' : 'Fork';
}

/**
 * 获取 Worker 脚本路径
 */
function getWorkerScriptPath (): string {
  return __filename.endsWith('.mjs')
    ? path.join(__dirname, 'napcat.mjs')
    : path.join(__dirname, 'napcat.js');
}

/**
 * 检查进程是否存在
 */
function isProcessAlive (pid: number): boolean {
  try {
    process.kill(pid, 0);
    return true;
  } catch {
    return false;
  }
}

/**
 * 强制终止进程
 */
function forceKillProcess (pid: number): void {
  try {
    process.kill(pid, 'SIGKILL');
    logger.log(`[NapCat] [Process] 已强制终止进程 ${pid}`);
  } catch (error) {
    logger.logError(`[NapCat] [Process] 强制终止进程失败:`, error);
  }
}

/**
 * 重启 Worker 进程
 */
export async function restartWorker (): Promise<void> {
  logger.log('[NapCat] [Process] 正在重启Worker进程...');

  if (!currentWorker) {
    logger.logWarn('[NapCat] [Process] 没有运行中的Worker进程');
    await startWorker();
    return;
  }

  const workerPid = currentWorker.pid;
  logger.log(`[NapCat] [Process] 准备关闭Worker进程，PID: ${workerPid}`);

  // 1. 通知旧进程准备重启（旧进程会自行退出）
  currentWorker.postMessage({ type: 'restart-prepare' });

  // 2. 等待进程退出（最多 5 秒，给更多时间让进程自行清理）
  await new Promise<void>((resolve) => {
    const timeout = setTimeout(() => {
      logger.logWarn('[NapCat] [Process] Worker进程未在 5 秒内退出，尝试发送强制关闭信号');
      currentWorker?.postMessage({ type: 'shutdown' });

      // 再等待 2 秒
      setTimeout(() => {
        logger.logWarn('[NapCat] [Process] Worker进程仍未退出，尝试 kill');
        currentWorker?.kill();
        resolve();
      }, 2000);
    }, 5000);

    currentWorker?.once('exit', () => {
      clearTimeout(timeout);
      logger.log('[NapCat] [Process] Worker进程已正常退出');
      resolve();
    });
  });

  // 3. 二次确认进程是否真的被终止（兜底检查）
  if (workerPid) {
    logger.log(`[NapCat] [Process] 检查进程 ${workerPid} 是否已终止...`);

    if (isProcessAlive(workerPid)) {
      logger.logWarn(`[NapCat] [Process] 进程 ${workerPid} 仍在运行，尝试强制杀掉（兜底）`);
      forceKillProcess(workerPid);

      // 等待 1 秒后再次检查
      await new Promise(resolve => setTimeout(resolve, 1000));

      if (isProcessAlive(workerPid)) {
        logger.logError(`[NapCat] [Process] 进程 ${workerPid} 无法终止，可能需要手动处理`);
      } else {
        logger.log(`[NapCat] [Process] 进程 ${workerPid} 已被强制终止`);
      }
    } else {
      logger.log(`[NapCat] [Process] 进程 ${workerPid} 已确认终止`);
    }
  }

  // 4. 等待 3 秒后启动新进程
  logger.log('[NapCat] [Process] Worker进程已关闭，等待 3 秒后启动新进程...');
  await new Promise(resolve => setTimeout(resolve, 3000));

  // 5. 启动新进程
  await startWorker();
  logger.log('[NapCat] [Process] Worker进程重启完成');
}

/**
 * 启动 Worker 进程
 */
async function startWorker (): Promise<void> {
  if (!processManager) {
    throw new Error('进程管理器未初始化');
  }

  const workerScript = getWorkerScriptPath();
  const processType = getProcessTypeName();

  const child = processManager.createWorker(workerScript, [], {
    env: {
      ...process.env,
      NAPCAT_WORKER_PROCESS: '1',
    },
    stdio: isElectron ? 'pipe' : ['inherit', 'pipe', 'pipe', 'ipc'],
  });

  currentWorker = child;

  // 监听标准输出（直接转发）
  if (child.stdout) {
    child.stdout.on('data', (data: Buffer) => {
      process.stdout.write(data);
    });
  }

  // 监听标准错误（直接转发）
  if (child.stderr) {
    child.stderr.on('data', (data: Buffer) => {
      process.stderr.write(data);
    });
  }

  // 监听子进程消息
  child.on('message', (msg: unknown) => {
    logger.log(`[NapCat] [${processType}] 收到Worker消息:`, msg);

    // 处理重启请求
    if (typeof msg === 'object' && msg !== null && 'type' in msg && msg.type === 'restart') {
      logger.log(`[NapCat] [${processType}] 收到重启请求，正在重启Worker进程...`);
      restartWorker().catch(e => {
        logger.logError(`[NapCat] [${processType}] 重启Worker进程失败:`, e);
      });
    }
  });

  // 监听子进程退出
  child.on('exit', (code: unknown) => {
    const exitCode = typeof code === 'number' ? code : 0;
    if (exitCode !== 0) {
      logger.logError(`[NapCat] [${processType}] Worker进程退出，退出码: ${exitCode}`);
    } else {
      logger.log(`[NapCat] [${processType}] Worker进程正常退出`);
    }
  });

  child.on('spawn', () => {
    logger.log(`[NapCat] [${processType}] Worker进程已生成`);
  });
}

/**
 * 启动 Master 进程
 */
async function startMasterProcess (): Promise<void> {
  const processType = getProcessTypeName();
  logger.log(`[NapCat] [${processType}] Master进程启动，PID: ${process.pid}`);

  // 连接命名管道（可通过环境变量禁用）
  if (!ENV.isPipeDisabled) {
    await connectToNamedPipe(logger).catch(e =>
      logger.logError('命名管道连接失败', e)
    );
  } else {
    logger.log(`[NapCat] [${processType}] 命名管道已禁用 (NAPCAT_DISABLE_PIPE=1)`);
  }

  // 启动 Worker 进程
  await startWorker();

  // 优雅关闭处理
  const shutdown = (signal: string) => {
    logger.log(`[NapCat] [Process] 收到${signal}信号，正在关闭...`);

    if (currentWorker) {
      currentWorker.postMessage({ type: 'shutdown' });
      setTimeout(() => {
        currentWorker?.kill();
        process.exit(0);
      }, 1000);
    } else {
      process.exit(0);
    }
  };

  process.on('SIGINT', () => shutdown('SIGINT'));
  process.on('SIGTERM', () => shutdown('SIGTERM'));
}

/**
 * 启动 Worker 进程（子进程入口）
 */
async function startWorkerProcess (): Promise<void> {
  if (!processManager) {
    throw new Error('进程管理器未初始化');
  }

  const processType = getProcessTypeName();
  logger.log(`[NapCat] [${processType}] Worker进程启动，PID: ${process.pid}`);

  // 监听来自父进程的消息
  processManager.onParentMessage((msg: unknown) => {
    if (typeof msg === 'object' && msg !== null && 'type' in msg) {
      if (msg.type === 'restart-prepare') {
        // 收到重启准备信号，主动退出
        logger.log(`[NapCat] [${processType}] 收到重启准备信号，正在主动退出...`);
        // 给一点时间让日志输出
        setTimeout(() => {
          process.exit(0);
        }, 100);
      } else if (msg.type === 'shutdown') {
        // 收到强制关闭信号
        logger.log(`[NapCat] [${processType}] 收到关闭信号，正在退出...`);
        process.exit(0);
      }
    }
  });

  // 注册重启进程函数到 WebUI
  WebUiDataRuntime.setRestartProcessCall(async () => {
    try {
      const success = processManager!.sendToParent({ type: 'restart' });

      if (success) {
        return { result: true, message: '进程重启请求已发送' };
      } else {
        return { result: false, message: '无法与主进程通信' };
      }
    } catch (e) {
      logger.logError('[NapCat] [Process] 发送重启请求失败:', e);
      return {
        result: false,
        message: '发送重启请求失败: ' + (e as Error).message
      };
    }
  });

  // 启动 NapCat 核心
  await NCoreInitShell();
}

/**
 * 主入口
 */
async function main (): Promise<void> {
  // 单进程模式：直接启动核心
  if (ENV.isMultiProcessDisabled) {
    logger.log('[NapCat] [SingleProcess] 多进程模式已禁用，直接启动核心');
    await NCoreInitShell();
    return;
  }

  // 多进程模式：初始化进程管理器
  const result = await createProcessManager();
  processManager = result.manager;
  isElectron = result.isElectron;

  logger.log(`[NapCat] [Process] 检测到 ${isElectron ? 'Electron' : 'Node.js'} 环境`);

  // 根据进程类型启动
  if (ENV.isWorkerProcess) {
    await startWorkerProcess();
  } else {
    await startMasterProcess();
  }
}

// 启动应用
main().catch((e: Error) => {
  logger.logError('[NapCat] [Process] 启动失败:', e);
  process.exit(1);
});