http.js

import config from "./config.js";

import https from "node:https";
import http from "node:http";
import axios from "axios";

const agents = {};

export async function requestOpFwApi(url, token) {
    const agent = getInstance(url);

    const response = await axios.get(url, {
        httpAgent: agent,
        timeout: config.timeout || 3000,
        headers: {
            "Authorization": `Bearer ${token}`
        }
    });

    if (response.status !== 200) {
        throw Error("http status code not 200");
    }

    const json = response.data;

    if (!json || typeof json !== "object" || !("data" in json) || !("statusCode" in json)) {
        throw Error("invalid json returned");
    }

    if (json.statusCode !== 200) {
        throw Error("json status code not 200");
    }

    return json.data;
}

function getInstance(uri) {
    const url = new URL(uri),
        origin = url.origin;

    if (!(origin in agents)) {
        const agent = url.scheme === "https" ? new https.Agent({
            keepAlive: true,
            rejectUnauthorized: false,
            keepAliveMsecs: 5000,
        }) : new http.Agent({
            keepAlive: true,
            keepAliveMsecs: 5000,
        });

        agents[origin] = agent;
    }

    return agents[origin];
}