using System.Text;
using System.Text.Json;
using System.Text.Json.Nodes;
using Json.Schema;
using Microsoft.Extensions.Logging;

namespace NeonSprawl.Server.Game.Gathering;

/// <summary>Loads and validates <c>content/resource-nodes/*.json</c> using the same rules as <c>scripts/validate_content.py</c> (NEO-58).</summary>
public static class ResourceNodeCatalogLoader
{
    /// <summary>Loads catalogs from disk or throws <see cref="InvalidOperationException"/> with actionable messages.</summary>
    public static ResourceNodeCatalog Load(
        string resourceNodesDirectory,
        string nodeSchemaPath,
        string yieldSchemaPath,
        IReadOnlySet<string> knownItemIds,
        ILogger logger)
    {
        resourceNodesDirectory = Path.GetFullPath(resourceNodesDirectory);
        nodeSchemaPath = Path.GetFullPath(nodeSchemaPath);
        yieldSchemaPath = Path.GetFullPath(yieldSchemaPath);

        var errors = new List<string>();

        if (!File.Exists(nodeSchemaPath))
            errors.Add($"error: missing schema file {nodeSchemaPath}");

        if (!File.Exists(yieldSchemaPath))
            errors.Add($"error: missing schema file {yieldSchemaPath}");

        if (!Directory.Exists(resourceNodesDirectory))
            errors.Add($"error: missing directory {resourceNodesDirectory}");

        if (errors.Count > 0)
            ThrowIfAny(errors);

        var nodeJsonFiles = Directory.GetFiles(resourceNodesDirectory, "*_resource_nodes.json", SearchOption.TopDirectoryOnly)
            .OrderBy(p => p, StringComparer.Ordinal)
            .ToArray();
        if (nodeJsonFiles.Length == 0)
            errors.Add($"error: no *_resource_nodes.json files under {resourceNodesDirectory}");

        var yieldJsonFiles = Directory.GetFiles(resourceNodesDirectory, "*_resource_yields.json", SearchOption.TopDirectoryOnly)
            .OrderBy(p => p, StringComparer.Ordinal)
            .ToArray();
        if (yieldJsonFiles.Length == 0)
            errors.Add($"error: no *_resource_yields.json files under {resourceNodesDirectory}");

        if (errors.Count > 0)
            ThrowIfAny(errors);

        var nodeSchema = JsonSchema.FromText(File.ReadAllText(nodeSchemaPath));
        var yieldSchema = JsonSchema.FromText(File.ReadAllText(yieldSchemaPath));
        var evalOptions = new EvaluationOptions { OutputFormat = OutputFormat.List };

        var nodeDefIdToSourceFile = new Dictionary<string, string>(StringComparer.Ordinal);
        var idToGatherLens = new Dictionary<string, string>(StringComparer.Ordinal);
        var nodes = new Dictionary<string, ResourceNodeDefRow>(StringComparer.Ordinal);

        foreach (var path in nodeJsonFiles)
        {
            JsonNode? root;
            try
            {
                root = JsonNode.Parse(File.ReadAllText(path));
            }
            catch (JsonException ex)
            {
                errors.Add($"error: {path}: invalid JSON: {ex.Message}");
                continue;
            }

            if (root is not JsonObject rootObj)
            {
                errors.Add($"error: {path}: expected JSON object at root");
                continue;
            }

            var schemaVersionNode = rootObj["schemaVersion"];
            if (schemaVersionNode is not JsonValue schemaVersionValue ||
                !schemaVersionValue.TryGetValue<int>(out var schemaVersion) ||
                schemaVersion != 1)
            {
                var got = schemaVersionNode?.ToJsonString() ?? "null";
                errors.Add($"error: {path}: expected schemaVersion 1, got {got}");
                continue;
            }

            var nodesNode = rootObj["nodes"];
            if (nodesNode is not JsonArray nodesArray)
            {
                errors.Add($"error: {path}: expected top-level 'nodes' array");
                continue;
            }

            for (var i = 0; i < nodesArray.Count; i++)
            {
                var row = nodesArray[i];
                if (row is not JsonObject rowObj)
                {
                    errors.Add($"error: {path}: nodes[{i}] must be an object");
                    continue;
                }

                var eval = nodeSchema.Evaluate(rowObj, evalOptions);
                var schemaMsgs = CollectSchemaMessages(eval, path, "nodes", i).OrderBy(m => m, StringComparer.Ordinal).ToList();
                if (!eval.IsValid)
                {
                    if (schemaMsgs.Count == 0)
                        schemaMsgs.Add($"error: {path} nodes[{i}] (root): schema validation failed");

                    errors.AddRange(schemaMsgs);
                }

                var rowSchemaErrors = schemaMsgs.Count;

                var nodeDefId = (rowObj["nodeDefId"] as JsonValue)?.GetValue<string>();
                if (nodeDefId is not null && rowSchemaErrors == 0)
                {
                    if (nodeDefIdToSourceFile.TryGetValue(nodeDefId, out var prevPath))
                    {
                        errors.Add($"error: duplicate nodeDefId '{nodeDefId}' in {prevPath} and {path}");
                        continue;
                    }

                    nodeDefIdToSourceFile[nodeDefId] = path;

                    var gatherLens = (rowObj["gatherLens"] as JsonValue)?.GetValue<string>();
                    if (gatherLens is not null)
                        idToGatherLens[nodeDefId] = gatherLens;

                    nodes[nodeDefId] = ParseNodeRow(rowObj);
                }
            }
        }

        ThrowIfAny(errors);

        var slice2Node = PrototypeSlice2ResourceNodeCatalogRules.TryGetSlice2NodeGateError(
            nodeDefIdToSourceFile,
            idToGatherLens);
        if (slice2Node is not null)
        {
            errors.Add(slice2Node);
            ThrowIfAny(errors);
        }

        var knownNodeIds = nodeDefIdToSourceFile.Keys.ToHashSet(StringComparer.Ordinal);
        var yieldNodeDefIdToSourceFile = new Dictionary<string, string>(StringComparer.Ordinal);
        var yieldItemIds = new HashSet<string>(StringComparer.Ordinal);
        var yields = new Dictionary<string, ResourceYieldRow>(StringComparer.Ordinal);

        foreach (var path in yieldJsonFiles)
        {
            JsonNode? root;
            try
            {
                root = JsonNode.Parse(File.ReadAllText(path));
            }
            catch (JsonException ex)
            {
                errors.Add($"error: {path}: invalid JSON: {ex.Message}");
                continue;
            }

            if (root is not JsonObject rootObj)
            {
                errors.Add($"error: {path}: expected JSON object at root");
                continue;
            }

            var schemaVersionNode = rootObj["schemaVersion"];
            if (schemaVersionNode is not JsonValue schemaVersionValue ||
                !schemaVersionValue.TryGetValue<int>(out var schemaVersion) ||
                schemaVersion != 1)
            {
                var got = schemaVersionNode?.ToJsonString() ?? "null";
                errors.Add($"error: {path}: expected schemaVersion 1, got {got}");
                continue;
            }

            var yieldsNode = rootObj["yields"];
            if (yieldsNode is not JsonArray yieldsArray)
            {
                errors.Add($"error: {path}: expected top-level 'yields' array");
                continue;
            }

            for (var i = 0; i < yieldsArray.Count; i++)
            {
                var row = yieldsArray[i];
                if (row is not JsonObject rowObj)
                {
                    errors.Add($"error: {path}: yields[{i}] must be an object");
                    continue;
                }

                var eval = yieldSchema.Evaluate(rowObj, evalOptions);
                var schemaMsgs = CollectSchemaMessages(eval, path, "yields", i).OrderBy(m => m, StringComparer.Ordinal).ToList();
                if (!eval.IsValid)
                {
                    if (schemaMsgs.Count == 0)
                        schemaMsgs.Add($"error: {path} yields[{i}] (root): schema validation failed");

                    errors.AddRange(schemaMsgs);
                }

                var rowSchemaErrors = schemaMsgs.Count;

                var nodeDefId = (rowObj["nodeDefId"] as JsonValue)?.GetValue<string>();
                var itemId = (rowObj["itemId"] as JsonValue)?.GetValue<string>();
                if (nodeDefId is not null && rowSchemaErrors == 0)
                {
                    if (yieldNodeDefIdToSourceFile.TryGetValue(nodeDefId, out var prevPath))
                    {
                        errors.Add($"error: duplicate yield nodeDefId '{nodeDefId}' in {prevPath} and {path}");
                        continue;
                    }

                    yieldNodeDefIdToSourceFile[nodeDefId] = path;

                    if (!knownNodeIds.Contains(nodeDefId))
                    {
                        errors.Add(
                            $"error: {path} yields[{i}]: nodeDefId '{nodeDefId}' is not defined in resource node catalogs");
                        continue;
                    }

                    yields[nodeDefId] = ParseYieldRow(rowObj);
                }

                if (itemId is not null && rowSchemaErrors == 0)
                {
                    yieldItemIds.Add(itemId);
                    if (!knownItemIds.Contains(itemId))
                    {
                        errors.Add(
                            $"error: {path} yields[{i}]: itemId '{itemId}' is not in item catalogs");
                    }
                }
            }
        }

        ThrowIfAny(errors);

        var slice2Yield = PrototypeSlice2ResourceNodeCatalogRules.TryGetSlice2YieldGateError(
            yieldNodeDefIdToSourceFile.Keys.ToHashSet(StringComparer.Ordinal),
            yieldItemIds);
        if (slice2Yield is not null)
        {
            errors.Add(slice2Yield);
            ThrowIfAny(errors);
        }

        if (logger.IsEnabled(LogLevel.Information))
        {
            logger.LogInformation(
                "Loaded resource-node catalog from {ResourceNodesDirectory}: {NodeCount} node(s) across {NodeFileCount} node catalog file(s), {YieldCount} yield row(s) across {YieldFileCount} yield catalog file(s).",
                resourceNodesDirectory,
                nodes.Count,
                nodeJsonFiles.Length,
                yields.Count,
                yieldJsonFiles.Length);
        }

        return new ResourceNodeCatalog(
            resourceNodesDirectory,
            nodes,
            yields,
            nodeJsonFiles.Length,
            yieldJsonFiles.Length);
    }

    private static ResourceNodeDefRow ParseNodeRow(JsonObject rowObj)
    {
        var nodeDefId = (rowObj["nodeDefId"] as JsonValue)!.GetValue<string>();
        var displayName = (rowObj["displayName"] as JsonValue)!.GetValue<string>();
        var gatherLens = (rowObj["gatherLens"] as JsonValue)!.GetValue<string>();
        var maxGathers = (rowObj["maxGathers"] as JsonValue)!.GetValue<int>();
        return new ResourceNodeDefRow(nodeDefId, displayName, gatherLens, maxGathers);
    }

    private static ResourceYieldRow ParseYieldRow(JsonObject rowObj)
    {
        var nodeDefId = (rowObj["nodeDefId"] as JsonValue)!.GetValue<string>();
        var itemId = (rowObj["itemId"] as JsonValue)!.GetValue<string>();
        var quantity = (rowObj["quantity"] as JsonValue)!.GetValue<int>();
        return new ResourceYieldRow(nodeDefId, itemId, quantity);
    }

    private static List<string> CollectSchemaMessages(EvaluationResults eval, string filePath, string arrayName, int index)
    {
        var sink = new List<string>();
        AppendSchemaMessages(eval, filePath, arrayName, index, sink);
        return sink;
    }

    private static void AppendSchemaMessages(
        EvaluationResults r,
        string filePath,
        string arrayName,
        int index,
        List<string> sink)
    {
        if (r.HasDetails)
        {
            foreach (var d in r.Details!)
                AppendSchemaMessages(d, filePath, arrayName, index, sink);
        }

        if (!r.HasErrors)
            return;

        foreach (var kv in r.Errors!)
        {
            var loc = r.InstanceLocation?.ToString();
            if (string.IsNullOrEmpty(loc) || loc == "#")
                loc = "(root)";

            sink.Add($"error: {filePath} {arrayName}[{index}] {loc}: {kv.Key} — {kv.Value}");
        }
    }

    private static void ThrowIfAny(List<string> errors)
    {
        if (errors.Count == 0)
            return;

        var sb = new StringBuilder();
        sb.AppendLine("Resource node catalog validation failed:");
        foreach (var e in errors.OrderBy(x => x, StringComparer.Ordinal))
            sb.AppendLine(e);

        throw new InvalidOperationException(sb.ToString().TrimEnd());
    }
}