package eu.mrneznamy.mrlibcore.stats;

import eu.mrneznamy.mrlibcore.MrLibRegisterPlugin;
import eu.mrneznamy.mrlibcore.scheduler.MrLibScheduler;
import eu.mrneznamy.mrlibcore.utils.MrLibColors;
import eu.mrneznamy.mrlibcore.utils.MrLibConsoleSayer;
import org.bukkit.Bukkit;
import org.bukkit.plugin.java.JavaPlugin;

import java.io.*;
import java.net.URI;
import java.net.http.HttpClient;
import java.net.http.HttpRequest;
import java.net.http.HttpResponse;
import java.nio.charset.StandardCharsets;
import java.util.UUID;

/**
 * Custom analytics for MrNeznamy plugins.
 * Tracks active servers and reports automated crash reports.
 */
public class MrNeznamyStats {

    private static final String PING_URL = "https://dev.mrneznamy.eu/api/analytics/ping";
    private static final String ERROR_URL = "https://dev.mrneznamy.eu/api/analytics/report-error";
    private static final String SHUTDOWN_URL = "https://dev.mrneznamy.eu/api/analytics/shutdown";
    private static String serverHash;
    private static boolean accepted = false;
    private static final HttpClient client = HttpClient.newBuilder()
            .connectTimeout(java.time.Duration.ofSeconds(10))
            .build();

    /**
     * Initializes the statistics system.
     */
    public static void init(JavaPlugin core) {
        File file = new File(core.getDataFolder(), "server-id.txt");
        if (file.exists()) {
            accepted = true;
            serverHash = loadServerHash(file);
        } else {
            accepted = false;
            // Print notice to console after server has fully loaded
            MrLibScheduler.runTaskLater(core, () -> printPolicyToConsole(), 20 * 5);
        }
        
        // Start heartbeat ping task every 5 minutes
        MrLibScheduler.runTaskTimerAsynchronously(core, () -> {
            if (!accepted) return;
            for (MrLibRegisterPlugin.RegisteredPlugin registered : MrLibRegisterPlugin.getAllPlugins().values()) {
                sendPing(registered);
            }
        }, 20 * 10, 20 * 60 * 5);
    }

    public static void shutdown() {
        if (!accepted || serverHash == null) return;
        
        for (MrLibRegisterPlugin.RegisteredPlugin registered : MrLibRegisterPlugin.getAllPlugins().values()) {
            String slug = registered.getModrinthSlug();
            if (slug == null || slug.isEmpty()) slug = registered.getName().toLowerCase();
            
            String json = String.format("{\"plugin_slug\":\"%s\",\"server_hash\":\"%s\"}", 
                escapeJson(slug), escapeJson(serverHash));
            
            sendPostSync(SHUTDOWN_URL, json);
        }
    }

    public static void reportError(String pluginSlug, Throwable throwable, String message) {
        if (!accepted || serverHash == null) return;

        StringWriter sw = new StringWriter();
        PrintWriter pw = new PrintWriter(sw);
        throwable.printStackTrace(pw);
        String stackTrace = sw.toString();

        String mcVersion = Bukkit.getBukkitVersion().split("-")[0];
        String javaVersion = System.getProperty("java.version");
        String msg = maskPrivateInfo(message != null ? message : throwable.toString());
        String maskedStackTrace = maskPrivateInfo(stackTrace);
        
        String json = String.format(
            "{\"plugin_slug\":\"%s\",\"message\":\"%s\",\"stack_trace\":\"%s\",\"java_version\":\"%s\",\"mc_version\":\"%s\"}",
            escapeJson(pluginSlug), escapeJson(msg), escapeJson(maskedStackTrace), escapeJson(javaVersion), escapeJson(mcVersion)
        );

        sendPost(ERROR_URL, json);
    }

    private static String maskPrivateInfo(String text) {
        if (text == null) return null;
        text = text.replaceAll("\\b(?:\\d{1,3}\\.){3}\\d{1,3}\\b", "// PRIVATE INFORMATION //");
        text = text.replaceAll("(?i)[A-Z]:\\\\Users\\\\[^\\\\\\s]+", "// PRIVATE INFORMATION //");
        text = text.replaceAll("/home/[^/\\s]+", "// PRIVATE INFORMATION //");
        text = text.replaceAll("/Users/[^/\\s]+", "// PRIVATE INFORMATION //");
        return text;
    }

    private static void sendPostSync(String url, String json) {
        try {
            HttpRequest request = HttpRequest.newBuilder()
                    .uri(URI.create(url))
                    .header("Content-Type", "application/json")
                    .POST(HttpRequest.BodyPublishers.ofString(json, StandardCharsets.UTF_8))
                    .build();
            client.send(request, HttpResponse.BodyHandlers.ofString());
        } catch (Exception ignored) {}
    }

    private static void sendPost(String url, String json) {
        try {
            HttpRequest request = HttpRequest.newBuilder()
                    .uri(URI.create(url))
                    .header("Content-Type", "application/json")
                    .POST(HttpRequest.BodyPublishers.ofString(json, StandardCharsets.UTF_8))
                    .build();
            client.sendAsync(request, HttpResponse.BodyHandlers.ofString());
        } catch (Exception e) {}
    }
}