const fs = require("fs");
const path = require("path");
const vm = require("vm");
const assert = require("assert");

const rootDir = path.resolve(__dirname, "..", "..");

const loadTokenModule = (injected = {}) => {
    const filePath = path.join(rootDir, "actions", "core", "token.js");
    let source = fs.readFileSync(filePath, "utf8");

    source = source.replace(/import[\s\S]*?from\s+"[^"]+";\n?/g, "");
    source = source.replace(/export const\s+/g, "const ");
    source += "\nmodule.exports = { getToken };\n";

    const context = {
        module: { exports: {} },
        exports: {},
        require,
        process: {
            env: {
                GRANT_TYPE: "client_credentials",
                CLIENT_ID: "client-id",
                CLIENT_SECRET: "client-secret",
                RELAYURI: "relay.local"
            }
        },
        ACCESS_TOKEN_ENDPOINT: "https://login.example/",
        TENANT_ID: "tenant-123",
        consoleLogger: () => {},
        requestJson: async () => {
            throw new Error("requestJson not injected");
        },
        ...injected
    };

    vm.runInNewContext(source, context, { filename: filePath });
    return context.module.exports;
};

const tests = [];
const test = (name, fn) => tests.push({ name, fn });

test("core/getToken returns token payload and calls requestJson with expected config", async () => {
    const calls = [];

    const mod = loadTokenModule({
        requestJson: async (config) => {
            calls.push(config);
            return { access_token: "abc", expires_in: 3600 };
        }
    });

    const result = await mod.getToken();

    assert.deepStrictEqual(JSON.parse(JSON.stringify(result)), {
        access_token: "abc",
        expires_in: 3600
    });
    assert.strictEqual(calls.length, 1);
    assert.strictEqual(
        calls[0].url,
        "https://login.example/tenant-123/oauth2/v2.0/token"
    );
    assert.strictEqual(calls[0].method, "post");
    assert.strictEqual(
        calls[0].data,
        "grant_type=client_credentials&client_id=client-id&client_secret=client-secret&scope=https://relay.local/.default"
    );
    assert.strictEqual(
        calls[0].headers["Content-Type"],
        "application/x-www-form-urlencoded"
    );
});

test("core/getToken logs and returns error object when requestJson throws", async () => {
    const loggerCalls = [];
    const error = new Error("token failed");

    const mod = loadTokenModule({
        consoleLogger: (err) => loggerCalls.push(err),
        requestJson: async () => {
            throw error;
        }
    });

    const result = await mod.getToken();

    assert.strictEqual(result, error);
    assert.strictEqual(loggerCalls.length, 1);
    assert.strictEqual(loggerCalls[0], error);
});

const run = async () => {
    let passed = 0;

    for (const currentTest of tests) {
        await currentTest.fn();
        passed += 1;
    }

    console.log(
        `Phase 22 core-token tests passed (${passed}/${tests.length}).`
    );
};

module.exports = run;

if (require.main === module) {
    run().catch((error) => {
        console.error(error);
        process.exit(1);
    });
}