Plugin.cs

// SPDX-License-Identifier: GPL-3.0-only
// Copyright (C) 2026 DNT_OF (https://github.com/DNTOF/SLDataAPI)

using System;
using Newtonsoft.Json.Linq;
using System.IO;
using LabApi.Events.Arguments.PlayerEvents;
using LabApi.Events.Arguments.ServerEvents;
using LabApi.Features.Wrappers;
using LabApi.Loader;
using LabApi.Loader.Features.Plugins;
using LabApi.Loader.Features.Yaml;
using MEC;
using SLDataAPI.Auth;
using SLDataAPI.Capture;
using SLDataAPI.Control;
using SLDataAPI.Map;
using SLDataAPI.Services;
using SLDataAPI.Voice;

namespace SLDataAPI;

public class Plugin : LabApi.Loader.Features.Plugins.Plugin<Config>
{
    public static Plugin? Instance;
    private HttpServer? server;

    public override string Name => "SLDataAPI";
    public override string Description => "通过 HTTP API 向外部（WebUI / 机器人）提供服务器数据采集与远程控制能力（LabAPI 原生插件，v2.6.2，代号 Holiday26）";
    public override string Author => "DNT_OF";
    public override Version Version => new Version(2, 6, 2);
    public override Version RequiredApiVersion => new Version(1, 1, 7);

    public override void Enable()
    {
        Instance = this;

        LabApi.Events.Handlers.ServerEvents.WaitingForPlayers += OnWaitingForPlayers;
        LabApi.Events.Handlers.ServerEvents.RoundStarted    += OnRoundStarted;
        LabApi.Events.Handlers.ServerEvents.RoundEnded      += OnRoundEnded;
        LabApi.Events.Handlers.PlayerEvents.Joined             += OnPlayerJoined;
        LabApi.Events.Handlers.PlayerEvents.Left               += OnPlayerLeft;
        LabApi.Events.Handlers.PlayerEvents.Death              += OnPlayerDeath;
        LabApi.Events.Handlers.PlayerEvents.InteractedElevator += OnInteractedElevator;
        LabApi.Events.Handlers.PlayerEvents.InteractedDoor     += OnInteractedDoor;
        // WS 事件流扩展（封禁/踢出/波次/去污/核弹/发电机/收容播报/逃脱/角色变化/举报；仅低频事件）
        WsEventBridge.Register();

        // 节日门控测试钩子：仅当设置了环境变量时生效，且只会把节日功能判为“未开启”，不会放宽游戏限制
        try
        {
            string? holidayOverride = Environment.GetEnvironmentVariable(HolidayGate.OverrideEnvVar);
            if (!string.IsNullOrWhiteSpace(holidayOverride))
            {
                if (HolidayGate.SetTestOverride(holidayOverride))
                    Log.Warn($"[SLDataAPI] 测试钩子 {HolidayGate.OverrideEnvVar}={HolidayGate.TestOverride}：节日门控按该节日模拟判定（只收紧不放宽），勿用于生产服。");
                else
                    Log.Warn($"[SLDataAPI] 忽略无效的 {HolidayGate.OverrideEnvVar} 值（支持 None / Christmas / Halloween / AprilFools）。");
            }
        }
        catch (Exception ex)
        {
            Log.Debug($"[SLDataAPI] 读取 {HolidayGate.OverrideEnvVar} 失败（忽略）: {ex.Message}");
        }

        // 命令输出捕获（patch ServerConsole.AddLog）
        CommandOutputCapture.Init();

        ValidateConfigFileIntegrity();
        ValidateControlConfig();

        // [内测] beta 开关（默认全关）：discovery 是否列出适配插件 actions；启动时明确打印，避免"以为开了其实没开"
        SLDataAPI.Integrations.PluginEndpointRegistry.ActionsEnabled = Config.BetaAdaptedPluginActions;
        if (Config.BetaAdaptedPluginActions || Config.BetaFileRootWs)
        {
            Log.Warn(
                "[SLDataAPI] 内测功能已开启（仅供内测，勿用于公网生产服）：" +
                $"beta_adapted_plugin_actions={(Config.BetaAdaptedPluginActions ? "开 → POST /control/adapted/<id>/<action>（ACL 默认拒绝，需 endpoints_override 显式授权）" : "关")}，" +
                $"beta_file_root_ws={(Config.BetaFileRootWs ? (string.IsNullOrWhiteSpace(Config.FileRoot) ? "开（但 file_root 为空，文件端点仍不可用）" : "开 → /control/files/{stat,read_chunk,write_chunk}") : "关")}。");
        }

        bool dataPlaneOk = ControlAuth.IsAcceptableVerifyToken(Config.VerifyToken);
        if (!dataPlaneOk)
        {
            string why = ControlAuth.DescribeVerifyTokenRejection(Config.VerifyToken);
            Log.Error(
                "[SLDataAPI] verify_token 未通过 fail-closed 校验（" + why + "）。" +
                "必须设置强随机值（长度≥8，同时含大写/小写/数字/特殊符号，且不得为出厂默认 your_secret_token）。" +
                (Config.ControlEnabled
                    ? "数据口（/get_sl_data 等）将拒绝服务；HTTP 端口仅在控制面需要时绑定。"
                    : "本次不会绑定数据 HTTP 监听。"));
        }

        // 数据接口 token 的引号检测（控制 token 的检测在 ValidateControlConfig，更严格：直接禁用）
        if (ContainsQuoteChar(Config.VerifyToken))
            Log.Warn("[SLDataAPI] VerifyToken 中检测到引号字符（可能是从聊天软件复制的弯引号 ‘ ’ “ ”）——" +
                     "引号会被当作 token 内容导致鉴权失败，请删除引号后重启服务器。");

        // 生效配置摘要（一眼识别"配置没被读到、正在用默认值"的状态）
        Log.Info(
            $"[SLDataAPI] 配置摘要：http_port={Config.HttpPort}，verify_token 长度 {Config.VerifyToken?.Length ?? 0}" +
            $"{(dataPlaneOk ? "" : "（数据口已关闭）")}，" +
            $"control={(Config.ControlEnabled ? $"{Config.ControlTransport} 模式，API Key 鉴权" : "关闭")}，" +
            $"voice={(Config.VoiceEnabled ? $"启用(端口 {Config.VoicePort})" : "关闭")}，" +
            $"录音={(Config.VoiceRecordEnabled ? $"开(保留 {Config.VoiceRecordMaxRounds} 局)" : "关")}，" +
            $"webdav={(Config.WebdavUploadEnabled ? "开" : "关")}。");

        // 插件配置目录（configs/<port>/SLDataAPI/）：TLS 证书、举报、API Key、审计日志共用
        string reportConfigDir = "";
        try { reportConfigDir = Path.GetDirectoryName(ConfigurationLoader.GetConfigPath(this, ConfigFileName)) ?? ""; } catch { /* 目录获取失败则按禁用处理 */ }

        // 自签 TLS（contract v1）：必须在 HTTP / 语音监听启动前完成证书加载/生成
        string tlsBanner = TlsCertificateService.Init(Config.TlsMode, reportConfigDir);
        Log.Info("[SLDataAPI] " + tlsBanner);

        // 弱/默认 verify_token：不绑定 HTTP，除非控制面已启用（同端口还要伺候 /control）。
        if (dataPlaneOk || Config.ControlEnabled)
        {
            server = new HttpServer(Config.HttpPort, Config);
            try
            {
                server.Start();
            }
            catch (Exception ex)
            {
                // X-03：端口绑定失败（被占用/权限）时明确报错并跳过 HTTP 相关初始化，
                // 其余功能（语音/采集/更新）继续——避免插件"半死"状态且无日志
                Log.Error($"[SLDataAPI] HTTP 服务启动失败（端口 {Config.HttpPort} 可能被占用）: {ex.Message} —— 数据/控制接口不可用，其余功能继续");
                server = null;
            }
        }
        else
        {
            server = null;
        }

        // 语音转发（v2.3）：独立 WebSocket 端口，API Key 鉴权
        if (Config.VoiceEnabled)
        {
            LabApi.Events.Handlers.PlayerEvents.SendingVoiceMessage += OnSendingVoiceMessage;
            VoiceService.Start(Config.VoicePort);
        }

        // 语音录音取证（v2.5）：每局自动保存 WAV + 时间轴日志
        VoiceRecorder.Configure(Config.VoiceRecordEnabled, Config.VoiceRecordMaxRounds, Config.VoiceRecordDir);
        WebDavUploadService.Init(Config);
        VoiceRecorder.OnZipFinalized = WebDavUploadService.Enqueue;

        // 举报功能（v2.5.4 推出，代号 GIS,GNSS,RS!）：SSS 面板举报 + 平台端点，默认关闭
        ReportService.Init(Config.ReportEnabled, Config.ReportMaxRecords, Config.ReportRateLimit, Config.ReportRateWindowMinutes, reportConfigDir);

        // API Key（v2.6.0 推出，代号 PEAK）：控制面 / 语音 / 控制 WS 鉴权；与 verify_token 双轨
        ApiKeyService.Init(reportConfigDir);

        // 控制操作审计日志（v2.5.5-preview 推出，代号 Everest C1）：主动侵入性操作记录，默认开启
        ControlLogService.Init(Config.ControlLogEnabled, Config.ControlLogMaxRecords, reportConfigDir);

        // 插件启用时立即采集一次真实数据，并启动定时循环
        DataCollector.InitData(Config.PushIntervalSeconds);

        if (Config.AutoUpdateCheck)
            UpdateChecker.Start(Version, Config.AutoUpdateInstall, Config.AutoUpdateCheckIntervalHours, reportConfigDir);

        string httpStatus = server != null
            ? $"HTTP on port {Config.HttpPort}" + (dataPlaneOk ? "" : "（仅控制面，数据口已关闭）")
            : "HTTP 未绑定";
        Log.Info($"SLDataAPI v{Version} (2.6.2 Holiday26 / LabAPI) enabled. {httpStatus}. Control API: {(Config.ControlEnabled ? $"{Config.ControlTransport.ToUpperInvariant()} 模式，API Key" : "关闭")}. Voice: {(Config.VoiceEnabled ? $"启用(端口 {Config.VoicePort})" : "关闭")}. {tlsBanner}.");
    }

    public override void Disable()
    {
        LabApi.Events.Handlers.ServerEvents.WaitingForPlayers -= OnWaitingForPlayers;
        LabApi.Events.Handlers.ServerEvents.RoundStarted    -= OnRoundStarted;
        LabApi.Events.Handlers.ServerEvents.RoundEnded      -= OnRoundEnded;
        LabApi.Events.Handlers.PlayerEvents.Joined             -= OnPlayerJoined;
        LabApi.Events.Handlers.PlayerEvents.Left               -= OnPlayerLeft;
        LabApi.Events.Handlers.PlayerEvents.Death              -= OnPlayerDeath;
        LabApi.Events.Handlers.PlayerEvents.InteractedElevator -= OnInteractedElevator;
        LabApi.Events.Handlers.PlayerEvents.InteractedDoor     -= OnInteractedDoor;
        LabApi.Events.Handlers.PlayerEvents.SendingVoiceMessage -= OnSendingVoiceMessage;
        WsEventBridge.Unregister();
        HolidayGate.SetTestOverride(null);

        VoiceService.Stop();
        VoiceRecorder.EndRound(waitFinalize: true); // 兜底：停服时定稿并等待打包完成（回调入队 WebDAV）
        VoiceRecorder.OnZipFinalized = null;
        WebDavUploadService.Shutdown();
        ReportService.Dispose();
        server?.Stop();
        ControlController.ClearPluginStaged(); // X-05：插件重载后清空启停暂存
        ControlController.ClearFileUploads();  // [内测] 丢弃未完成的分块上传
        SLDataAPI.Integrations.PluginEndpointRegistry.ActionsEnabled = false;
        WsControlService.ShutdownAll();
        DataCollector.StopTimer();
        UpdateChecker.Stop();
        CommandOutputCapture.Shutdown();

        Instance = null;
    }

    // ────────────── WS 事件流推送（订阅了事件的会话实时接收） ──────────────

    private void OnPlayerJoined(PlayerJoinedEventArgs ev)
    {
        var p = ev.Player;
        WsControlService.BroadcastEvent("player_joined", new JObject
        {
            ["nickname"] = p.Nickname ?? "?",
            ["userid"] = p.UserId ?? "",
        });
        ReportService.OnPlayersChanged(); // 举报下拉：玩家列表变化即时刷新
    }

    private void OnPlayerLeft(PlayerLeftEventArgs ev)
    {
        var p = ev.Player;
        WsControlService.BroadcastEvent("player_left", new JObject
        {
            ["nickname"] = p.Nickname ?? "?",
            ["userid"] = p.UserId ?? "",
        });
        ReportService.OnPlayersChanged(); // 举报下拉：玩家列表变化即时刷新
    }

    private void OnPlayerDeath(PlayerDeathEventArgs ev)
    {
        try
        {
            var p = ev.Player;
            var d = new JObject
            {
                ["nickname"] = p.Nickname ?? "?",
                ["userid"] = p.UserId ?? "",
                ["old_role"] = ev.OldRole.ToString(),
            };
            if (ev.Attacker != null)
            {
                d["attacker_nickname"] = ev.Attacker.Nickname ?? "?";
                d["attacker_userid"] = ev.Attacker.UserId ?? "";
            }
            WsControlService.BroadcastEvent("player_died", d);
        }
        catch (Exception ex)
        {
            // 事件链保护：推送失败只丢事件，不得影响游戏回合流程
            Log.Debug($"[SLDataAPI] Death 事件推送异常（忽略）: {ex.Message}");
        }
    }

    private void OnInteractedElevator(PlayerInteractedElevatorEventArgs ev)
    {
        try
        {
            var p = ev.Player;
            WsControlService.BroadcastEvent("elevator_used", new JObject
            {
                ["nickname"] = p.Nickname ?? "?",
                ["userid"] = p.UserId ?? "",
                ["elevator_group"] = ev.Elevator?.Group.ToString() ?? "?",
            });
        }
        catch (Exception ex)
        {
            Log.Debug($"[SLDataAPI] InteractedElevator 事件推送异常（忽略）: {ex.Message}");
        }
    }

    private void OnInteractedDoor(PlayerInteractedDoorEventArgs ev)
    {
        try
        {
            var p = ev.Player;
            WsControlService.BroadcastEvent("door_opened", new JObject
            {
                ["nickname"] = p.Nickname ?? "?",
                ["userid"] = p.UserId ?? "",
                ["door"] = ev.Door?.DoorName.ToString() ?? "?",
                ["can_open"] = ev.CanOpen,
            });
        }
        catch (Exception ex)
        {
            Log.Debug($"[SLDataAPI] InteractedDoor 事件推送异常（忽略）: {ex.Message}");
        }
    }

    private void OnSendingVoiceMessage(PlayerSendingVoiceMessageEventArgs ev)
    {
        if (!ev.IsAllowed) return;
        var message = ev.Message; // Message 是 ref 属性，先拷贝副本再传递
        VoiceService.HandleIncoming(ev.Player, message);
    }

    /// <summary>
    /// 启动时校验控制接口配置。2.6：ControlToken 已废弃（警告后忽略）；
    /// 连接方式仅接受 http / ws（非法值回落 http）——只影响运行时状态，不改写配置文件。
    /// </summary>
    private void ValidateControlConfig()
    {
        if (!string.IsNullOrEmpty(Config.ControlToken))
        {
            Log.Warn(
                "[SLDataAPI] control_token 已在 v2.6.0（代号 PEAK）废弃，不再用于鉴权。" +
                "请改用 apikey.config + 命令 sldataapi apikey create；该字段将被忽略。");
        }

        if (!Config.ControlEnabled)
            return;

        string transport = (Config.ControlTransport ?? "http").Trim().ToLowerInvariant();
        if (transport != "http" && transport != "ws")
        {
            Log.Warn(
                $"[SLDataAPI] ControlTransport 值非法: \"{Config.ControlTransport}\"" +
                "（仅支持 http / ws，二选一硬互斥），本次运行按 http 处理。");
            transport = "http";
        }
        Config.ControlTransport = transport;
    }

    /// <summary>
    /// token 值是否包含引号字符（ASCII 单双引号或弯引号 ‘ ’ “ ”）。
    /// 弯引号不是 YAML 引号语法，会被 YamlDotNet 当作普通字符并入 token 值，
    /// 表现为"配置看着对、格式校验通过、鉴权却必败且无任何日志"。
    /// </summary>
    private static bool ContainsQuoteChar(string? s)
    {
        if (string.IsNullOrEmpty(s))
            return false;
        foreach (char c in s!) // net48 参考程序集缺 NotNullWhen 注解，编译器无法收窄，这里已判空
        {
            if (c == '\'' || c == '"' || c == '\u2018' || c == '\u2019' || c == '\u201C' || c == '\u201D')
                return true;
        }
        return false;
    }

    /// <summary>
    /// 配置文件完整性自检：用 LabAPI 同款反序列化器重读一遍配置文件。
    /// LabAPI 的 LoadConfigs 在任何值格式错误（布尔加引号变字符串 / Tab 缩进 / 行尾杂字符等）时，
    /// 会把【整个文件】静默回退到默认值且控制台无任何报错——鉴权失败、接口"未启用"
    /// 却找不到原因基本都是这个。这里把 YamlDotNet 的精确错误（含行号）暴露出来。
    /// </summary>
    private void ValidateConfigFileIntegrity()
    {
        try
        {
            string? path = ConfigurationLoader.GetConfigPath(this, ConfigFileName);
            if (string.IsNullOrEmpty(path) || !File.Exists(path))
                return; // 尚未生成配置文件（首次启动），属正常

            string text = File.ReadAllText(path);
            try
            {
                YamlConfigParser.Deserializer.Deserialize<Config>(text);
            }
            catch (Exception ex)
            {
                string detail = ex.Message.Replace("\n", " ");

                // YAML 特殊字符识别：token/路径以 * & ! 开头会被当成别名/锚点/tag——
                // * 开头直接解析失败，& 和 ! 开头值被吞成空（零报错）。给可读的排查提示
                if (detail.IndexOf("anchor", StringComparison.OrdinalIgnoreCase) >= 0 ||
                    detail.IndexOf("alias", StringComparison.OrdinalIgnoreCase) >= 0 ||
                    detail.IndexOf("tag", StringComparison.OrdinalIgnoreCase) >= 0)
                {
                    detail += " —— 疑似配置值含有 YAML 特殊字符" +
                              "（token 以 * / & / ! 开头会被当作别名/锚点/tag），" +
                              "请用 ASCII 双引号包裹该值，如 control_token: \"你的token\"";
                }

                Log.Error(
                    "[SLDataAPI] 配置文件解析失败！LabAPI 已静默回退到全部默认值（当前正以默认配置运行，" +
                    $"鉴权必然失败）。请修正配置文件后重启服务器。错误位置：{detail}");
            }
        }
        catch (Exception ex)
        {
            Log.Debug($"[SLDataAPI] 配置自检异常（忽略）: {ex.Message}");
        }
    }

    private void OnWaitingForPlayers()
    {
        DataCollector.UpdateDataNow();
        MapLayoutService.Clear(); // 上一回合的地图布局失效
        MapLayoutService.CaptureLayout(); // 等待玩家时地图已生成，立即采集（失败自动重试）
        Log.Info("SLDataAPI: Waiting for players.");
    }

    private void OnRoundStarted()
    {
        try
        {
            DataCollector.UpdateDataNow();
            MapLayoutService.CaptureLayout(); // 采集本回合随机布局（LCZ/HCZ 每回合不同）
            if (Config.VoiceEnabled)
                VoiceRecorder.BeginRound(); // 语音录音取证：本局开始（需语音管线运行）
            NotifyRecordingHint(); // 录音启用时向所有玩家声明本局将被录音（隐私告知）
            WsControlService.BroadcastEvent("round_started", new JObject
            {
                ["started_at"] = DateTime.UtcNow.ToString("o"),
            });
            Log.Info("SLDataAPI: Round started.");
        }
        catch (Exception ex)
        {
            // ★ 事件链保护：LabAPI 事件分发无 try-catch（InvokeEvent 裸调用），
            //   任何异常都会传播回游戏回合开始流程，导致回合初始化中断、
            //   玩家状态错乱（0 血/未注册/RA 查不到）——这里兜底并记录
            Log.Error($"[SLDataAPI] RoundStarted 处理器异常（已兜底）: {ex}");
        }
    }

    /// <summary>
    /// 录音启用时，每局开始向所有玩家显示 3 秒录音声明（隐私告知义务）。
    /// 延迟 1 秒显示：等待玩家完成出生动画，提示不易被切屏错过。
    /// 只发给真实玩家（HintDisplay.Show 对本地玩家会抛异常，NPC/dummy 无需告知）；
    /// 中途加入的玩家不会收到本提示（仅开局告知）。
    /// </summary>
    private void NotifyRecordingHint()
    {
        if (!Config.VoiceRecordEnabled || !Config.VoiceEnabled)
            return;

        const string text = "为了保证游戏公平性，本局游戏将会被录音，具体详询服务器管理员。";
        Timing.CallDelayed(1f, () =>
        {
            // N-06：延迟期间若回合已结束/重启，不再补发（避免提示迟到打到下一回合玩家）
            if (!Round.IsRoundStarted) return;
            try
            {
                foreach (var p in Player.List)
                {
                    if (p.IsHost || p.IsNpc || p.IsDummy || !p.IsPlayer || !p.IsReady)
                        continue;
                    try { p.SendHint(text, 3f); }
                    catch { /* 个别玩家断开等瞬态异常忽略 */ }
                }
            }
            catch (Exception ex)
            {
                Log.Warn($"[SLDataAPI] 录音声明提示发送异常（忽略）: {ex.Message}");
            }
        });
    }

    private void OnRoundEnded(RoundEndedEventArgs ev)
    {
        try
        {
            DataCollector.UpdateDataNow();
            if (Config.VoiceEnabled)
                VoiceRecorder.EndRound(); // 语音录音取证：定稿本局录音
            WsControlService.BroadcastEvent("round_ended", new JObject
            {
                ["leading_team"] = ev.LeadingTeam.ToString(),
                ["ended_at"] = DateTime.UtcNow.ToString("o"),
            });
            Log.Info("SLDataAPI: Round ended.");
        }
        catch (Exception ex)
        {
            // 事件链保护：异常不得传播回游戏回合结束流程
            Log.Error($"[SLDataAPI] RoundEnded 处理器异常（已兜底）: {ex}");
        }
    }
}