#include <cassert>
#include <filesystem>
#include <fstream>
#include <memory>
#include <string>
#include <unistd.h>
#include <utility>
#include <vector>

#include "TeamServerCommandCatalog.hpp"
#include "TeamServerCommandCatalogService.hpp"
#include "spdlog/logger.h"

namespace fs = std::filesystem;

namespace
{
class ScopedPath
{
public:
    explicit ScopedPath(fs::path path)
        : m_path(std::move(path))
    {
        std::error_code ec;
        fs::remove_all(m_path, ec);
        fs::create_directories(m_path);
    }

    ~ScopedPath()
    {
        std::error_code ec;
        fs::remove_all(m_path, ec);
    }

    const fs::path& path() const
    {
        return m_path;
    }

private:
    fs::path m_path;
};

fs::path makeTempDirectory(const std::string& name)
{
    return fs::temp_directory_path() / ("c2teamserver-command-catalog-" + name + "-" + std::to_string(::getpid()));
}

std::shared_ptr<spdlog::logger> makeLogger()
{
    auto logger = std::make_shared<spdlog::logger>("command-catalog-tests");
    logger->set_level(spdlog::level::off);
    return logger;
}

TeamServerRuntimeConfig makeRuntimeConfig(const fs::path& root)
{
    TeamServerRuntimeConfig runtimeConfig;
    runtimeConfig.commandSpecsDirectoryPath = (root / "CommandSpecs").string();
    fs::create_directories(runtimeConfig.commandSpecsDirectoryPath);
    return runtimeConfig;
}

void writeFile(const fs::path& path, const std::string& content)
{
    fs::create_directories(path.parent_path());
    std::ofstream output(path, std::ios::binary);
    output << content;
}

void seedCommandSpecs(const TeamServerRuntimeConfig& runtimeConfig)
{
    writeFile(
        fs::path(runtimeConfig.commandSpecsDirectoryPath) / "common" / "sleep.json",
        R"JSON({
  "name": "sleep",
  "display_name": "sleep",
  "kind": "common",
  "description": "Set beacon sleep interval.",
  "command_template": "sleep {seconds}",
  "target": "beacon",
  "requires_session": true,
  "platforms": ["windows", "linux"],
  "archs": ["any"],
  "args": [
    {
      "name": "seconds",
      "type": "number",
      "required": true,
      "description": "Sleep interval.",
      "completion_parents": ["interval"],
      "artifact_filter": {
        "category": "tool",
        "scope": "server",
        "target": "teamserver",
        "platform": "windows",
        "arch": "any",
        "runtime": "any",
        "format": "exe",
        "name_contains": ".exe"
      }
    }
  ],
  "examples": ["sleep 0.5"],
  "source": "manifest"
})JSON");
    writeFile(
        fs::path(runtimeConfig.commandSpecsDirectoryPath) / "common" / "end.json",
        R"JSON({
  "name": "end",
  "kind": "common",
  "description": "Terminate beacon.",
  "command_template": "end",
  "target": "beacon",
  "requires_session": true,
  "platforms": ["windows", "linux"],
  "archs": ["any"],
  "args": [],
  "examples": ["end"],
  "source": "manifest"
})JSON");
    writeFile(
        fs::path(runtimeConfig.commandSpecsDirectoryPath) / "modules" / "psExec.json",
        R"JSON({
  "name": "psExec",
  "kind": "module",
  "description": "Copy and run a service executable.",
  "command_template": "psExec {auth_mode} {username:q?} {password:q?} {target:q} {service_artifact:q}",
  "target": "beacon",
  "requires_session": true,
  "platforms": ["windows"],
  "archs": ["x86", "x64"],
  "args": [
    {
      "name": "service_artifact",
      "type": "artifact",
      "required": true,
      "description": "Service executable artifact.",
      "artifact_filters": [
        {
          "category": "tool",
          "scope": "server",
          "target": "teamserver",
          "platform": "windows",
          "arch": "session.arch",
          "runtime": "any",
          "name_contains": ".exe"
        },
        {
          "category": "upload",
          "scope": "operator",
          "target": "beacon",
          "platform": "session.platform",
          "arch": "session.arch",
          "runtime": "file",
          "name_contains": ".exe"
        }
      ]
    }
  ],
  "examples": ["psExec -n fileserver service.exe"],
  "source": "manifest"
})JSON");
    writeFile(fs::path(runtimeConfig.commandSpecsDirectoryPath) / "common" / "broken.json", "{");
}

const TeamServerCommandSpecRecord* findCommand(
    const std::vector<TeamServerCommandSpecRecord>& commands,
    const std::string& name)
{
    for (const TeamServerCommandSpecRecord& command : commands)
    {
        if (command.name == name)
            return &command;
    }
    return nullptr;
}

void testCommandCatalogLoadsManifestSpecs()
{
    ScopedPath tempRoot(makeTempDirectory("loads"));
    TeamServerRuntimeConfig runtimeConfig = makeRuntimeConfig(tempRoot.path());
    seedCommandSpecs(runtimeConfig);

    TeamServerCommandCatalog catalog(runtimeConfig);
    const std::vector<TeamServerCommandSpecRecord> commands = catalog.listCommands();

    assert(commands.size() == 3);

    const TeamServerCommandSpecRecord* sleep = findCommand(commands, "sleep");
    assert(sleep != nullptr);
    assert(sleep->kind == "common");
    assert(sleep->target == "beacon");
    assert(sleep->commandTemplate == "sleep {seconds}");
    assert(sleep->requiresSession);
    assert(sleep->platforms.size() == 2);
    assert(sleep->args.size() == 1);
    assert(sleep->args[0].name == "seconds");
    assert(sleep->args[0].type == "number");
    assert(sleep->args[0].required);
    assert(sleep->args[0].hasArtifactFilter);
    assert(sleep->args[0].artifactFilter.category == "tool");
    assert(sleep->args[0].artifactFilter.scope == "server");
    assert(sleep->args[0].artifactFilter.target == "teamserver");
    assert(sleep->args[0].artifactFilter.platform == "windows");
    assert(sleep->args[0].artifactFilter.arch == "any");
    assert(sleep->args[0].artifactFilter.runtime == "any");
    assert(sleep->args[0].artifactFilter.nameContains == ".exe");
    assert(sleep->args[0].artifactFilters.size() == 1);
    assert(sleep->args[0].completionParents.size() == 1);
    assert(sleep->args[0].completionParents[0] == "interval");
    assert(sleep->examples.size() == 1);

    const TeamServerCommandSpecRecord* end = findCommand(commands, "end");
    assert(end != nullptr);
    assert(end->args.empty());

    const TeamServerCommandSpecRecord* psExec = findCommand(commands, "psExec");
    assert(psExec != nullptr);
    assert(psExec->args.size() == 1);
    assert(psExec->args[0].hasArtifactFilter);
    assert(psExec->args[0].artifactFilters.size() == 2);
    assert(psExec->args[0].artifactFilters[0].category == "tool");
    assert(psExec->args[0].artifactFilters[0].arch == "session.arch");
    assert(psExec->args[0].artifactFilters[1].category == "upload");
    assert(psExec->args[0].artifactFilters[1].scope == "operator");
}

void testCommandCatalogFiltersSpecs()
{
    ScopedPath tempRoot(makeTempDirectory("filters"));
    TeamServerRuntimeConfig runtimeConfig = makeRuntimeConfig(tempRoot.path());
    seedCommandSpecs(runtimeConfig);

    TeamServerCommandCatalog catalog(runtimeConfig);
    TeamServerCommandQuery query;
    query.kind = "common";
    query.platform = "windows";
    query.nameContains = "sle";

    const std::vector<TeamServerCommandSpecRecord> commands = catalog.listCommands(query);
    assert(commands.size() == 1);
    assert(commands[0].name == "sleep");

    query.platform = "unsupported";
    assert(catalog.listCommands(query).empty());
}

void testCommandCatalogServiceStreamsProto()
{
    ScopedPath tempRoot(makeTempDirectory("service"));
    TeamServerRuntimeConfig runtimeConfig = makeRuntimeConfig(tempRoot.path());
    seedCommandSpecs(runtimeConfig);

    TeamServerCommandCatalogService service(makeLogger(), TeamServerCommandCatalog(runtimeConfig));
    teamserverapi::CommandQuery query;
    query.set_name_contains("sleep");

    std::vector<teamserverapi::CommandSpec> commands;
    assert(service.listCommands(query, [&](const teamserverapi::CommandSpec& command)
    {
        commands.push_back(command);
        return true;
    }).ok());

    assert(commands.size() == 1);
    assert(commands[0].name() == "sleep");
    assert(commands[0].kind() == "common");
    assert(commands[0].requires_session());
    assert(commands[0].command_template() == "sleep {seconds}");
    assert(commands[0].args_size() == 1);
    assert(commands[0].args(0).name() == "seconds");
    assert(commands[0].args(0).type() == "number");
    assert(commands[0].args(0).artifact_filter().category() == "tool");
    assert(commands[0].args(0).artifact_filter().scope() == "server");
    assert(commands[0].args(0).artifact_filter().target() == "teamserver");
    assert(commands[0].args(0).artifact_filter().platform() == "windows");
    assert(commands[0].args(0).artifact_filter().arch() == "any");
    assert(commands[0].args(0).artifact_filter().runtime() == "any");
    assert(commands[0].args(0).artifact_filter().format() == "exe");
    assert(commands[0].args(0).artifact_filter().name_contains() == ".exe");
    assert(commands[0].args(0).artifact_filters_size() == 1);
    assert(commands[0].args(0).artifact_filters(0).category() == "tool");
    assert(commands[0].args(0).completion_parents_size() == 1);
    assert(commands[0].args(0).completion_parents(0) == "interval");
    assert(commands[0].DebugString().find(tempRoot.path().string()) == std::string::npos);

    teamserverapi::CommandQuery psExecQuery;
    psExecQuery.set_name_contains("psexec");
    commands.clear();
    assert(service.listCommands(psExecQuery, [&](const teamserverapi::CommandSpec& command)
    {
        commands.push_back(command);
        return true;
    }).ok());

    assert(commands.size() == 1);
    assert(commands[0].name() == "psExec");
    assert(commands[0].args_size() == 1);
    assert(commands[0].args(0).artifact_filter().category() == "tool");
    assert(commands[0].args(0).artifact_filters_size() == 2);
    assert(commands[0].args(0).artifact_filters(0).category() == "tool");
    assert(commands[0].args(0).artifact_filters(1).category() == "upload");
    assert(commands[0].args(0).artifact_filters(1).scope() == "operator");
    assert(commands[0].args(0).artifact_filters(1).runtime() == "file");
}
} // namespace

int main()
{
    testCommandCatalogLoadsManifestSpecs();
    testCommandCatalogFiltersSpecs();
    testCommandCatalogServiceStreamsProto();
    return 0;
}