// чисто в теории это должно помочь долгой загрузке пакетов (так гемини сказал)
// на деле же хуй знает ибо там иногда хендшейк слетает и он просто заного его шлет
const xhrPool = [];
const MAX_POOL_SIZE = 6; // Qt's typical max concurrent connections

function getXhr() {
    // Look for an idle object
    for (let i = 0; i < xhrPool.length; i++) {
        if (xhrPool[i].readyState === 0 || xhrPool[i].readyState === 4) {
            return xhrPool[i];
        }
    }
    // If none idle and we have room, make a new one
    if (xhrPool.length < MAX_POOL_SIZE) {
        let newXhr = new XMLHttpRequest();
        xhrPool.push(newXhr);
        return newXhr;
    }
    // If all busy, return null (you should queue the request)
    return null;
}

// KeepAlive ping
function keepAlivePing() {
    let xhr = getXhr();

    if (!xhr) {
        console.log("Pool full, retrying...");
        setTimeout(() => keepAlivePing(), 100);
        return;
    }
    xhr.open("HEAD", "http://10.7.0.1:7777/me/profile");
    xhr.onreadystatechange = function() {
        if (xhr.readyState === XMLHttpRequest.DONE) {
            //isLoading = false;
            if (xhr.status === 200) {
                //console.log("ping pong")
            }
        }
    }
    xhr.send();
}

// GET routes
function fetchRoutes() {
    //isLoading = true;
    //routeModel.clear();

    let xhr = getXhr();

    if (!xhr) {
        console.log("Pool full, retrying...");
        setTimeout(() => fetchRoutes(), 100);
        return;
    }
    xhr.open("GET", "http://10.7.0.1:7777/routes");
    xhr.onreadystatechange = function() {
        if (xhr.readyState === XMLHttpRequest.DONE) {
            //isLoading = false;
            if (xhr.status === 200) {
                let response = JSON.parse(xhr.responseText);
                WorkerScript.sendMessage({ "action": "fetch_routes", "data": response });
                //for (var i = 0; i < response.length; i++) {
                //    routeModel.append(response[i]);
                //}
            } else {
                //WorkerScript.sendMessage({ "action": "fetch_routes", "data": [{"code":"ERR","name":"Error, please try again :<","provider":xhr.status}] });
                console.error("Failed to fetch routes:", xhr.status);
            }
        }
    }
    xhr.send();
}

// GET profile
function fetchProfile() {
    //isLoading = true;
    //profileModel.clear();

    let xhr = getXhr();

    if (!xhr) {
        console.log("Pool full, retrying...");
        setTimeout(() => fetchProfile(), 100);
        return;
    }
    xhr.open("GET", "http://10.7.0.1:7777/me/profile");
    xhr.onreadystatechange = function() {
        if (xhr.readyState === XMLHttpRequest.DONE) {
            //isLoading = false;
            if (xhr.status === 200) {
                let response = JSON.parse(xhr.responseText);
                WorkerScript.sendMessage({ "action": "fetch_profile", "data": response });
                //for (var i = 0; i < response.length; i++) {
                //    profileModel.append(response[i]);
                //}
            } else {
                //WorkerScript.sendMessage({ "action": "fetch_profile", "data": {"provider":xhr.status, "current_device":"error"} });
                console.error("Failed to fetch profile:", xhr.status);
            }
        }
    }
    xhr.send();
}

// GET stats
function fetchStats() {
    //isLoading = true;
    //statsModel.clear();

    let xhr = getXhr();

    if (!xhr) {
        console.log("Pool full, retrying...");
        setTimeout(() => fetchStats(), 100);
        return;
    }
    xhr.open("GET", "http://10.7.0.1:7777/stats");
    xhr.onreadystatechange = function() {
        if (xhr.readyState === XMLHttpRequest.DONE) {
            //isLoading = false;
            if (xhr.status === 200) {
                let response = JSON.parse(xhr.responseText);
                WorkerScript.sendMessage({ "action": "fetch_stats", "data": response });
                //for (var i = 0; i < response.length; i++) {
                //    profileModel.append(response[i]);
                //}
            } else {
                //WorkerScript.sendMessage({ "action": "fetch_stats", "data": {} });
                console.error("Failed to fetch profile:", xhr.status);
            }
        }
    }
    xhr.send();
}

// GET firewall
function fetchFirewall() {

    let xhr = getXhr();

    if (!xhr) {
        console.log("Pool full, retrying...");
        setTimeout(() => fetchFirewall(), 100);
        return;
    }
    xhr.open("GET", "http://10.7.0.1:7777/meowrok/get");
    xhr.onreadystatechange = function() {
        if (xhr.readyState === XMLHttpRequest.DONE) {
            if (xhr.status === 200) {
                let response = JSON.parse(xhr.responseText);
                WorkerScript.sendMessage({ "action": "fetch_firewall", "data": response });
            } else {
                console.error("Failed to fetch firewall:", xhr.status);
            }
        }
    }
    xhr.send();
}

// POST select country
function selectCountry(code, provider) {
    //isLoading = true;

    let xhr = getXhr();

    if (!xhr) {
        console.log("Pool full, retrying...");
        setTimeout(() => selectCountry(code, provider), 100);
        return;
    }
    xhr.open("POST", "http://10.7.0.1:7777/me/country");
    xhr.setRequestHeader("Content-Type", "application/json");

    var data = JSON.stringify({
        "countryCode": code,
        "provider": provider
    });

    xhr.onreadystatechange = function() {
        if (xhr.readyState === XMLHttpRequest.DONE) {
            //isLoading = false;
            if (xhr.status === 200) {
                console.log("Success: Changed to " + code);
                WorkerScript.sendMessage({ "action": "post_country", "status": xhr.status});
            } else {
                console.error("POST failed:", xhr.status);
                WorkerScript.sendMessage({ "action": "post_country", "status": xhr.status});
            }
        }
    }
    xhr.send(data);
}

// POST switch share
function switchShare(bool) {
    //isLoading = true;

    let xhr = getXhr();

    if (!xhr) {
        console.log("Pool full, retrying...");
        setTimeout(() => switchShare(bool), 100);
        return;
    }
    xhr.open("POST", "http://10.7.0.1:7777/me/profile");
    xhr.setRequestHeader("Content-Type", "application/json");

    var data = JSON.stringify({
        "shareTraffic": bool
    });

    xhr.onreadystatechange = function() {
        if (xhr.readyState === XMLHttpRequest.DONE) {
            //isLoading = false;
            if (xhr.status === 200) {
                console.log("Success: Share changed to " + bool);
                WorkerScript.sendMessage({ "action": "post_share", "status": xhr.status});
            } else {
                console.error("POST failed:", xhr.status);
                WorkerScript.sendMessage({ "action": "post_share", "status": xhr.status});
            }
        }
    }
    xhr.send(data);
}

// POST switch ebalka
function switchEbalka(bool, ip) {
    //isLoading = true;

    let xhr = getXhr();

    if (!xhr) {
        console.log("Pool full, retrying...");
        setTimeout(() => switchEbalka(bool, ip), 100);
        return;
    }
    xhr.open("POST", "http://10.7.0.1:7777/me/ebalka");
    xhr.setRequestHeader("Content-Type", "application/json");

    var data = JSON.stringify({
        "ebalka": bool,
        "ip": ip
    });

    xhr.onreadystatechange = function() {
        if (xhr.readyState === XMLHttpRequest.DONE) {
            //isLoading = false;
            if (xhr.status === 200) {
                console.log("Success: Ebalka for " + ip + " changed to " + bool);
                WorkerScript.sendMessage({ "action": "post_ebalka", "status": xhr.status, "ip": ip});
            } else {
                console.error("POST failed:", xhr.status);
                WorkerScript.sendMessage({ "action": "post_ebalka", "status": xhr.status, "ip": ip});
            }
        }
    }
    xhr.send(data);
}

// POST switch ebalka
function renameDevice(ip, name) {
    //isLoading = true;

    let xhr = getXhr();

    if (!xhr) {
        console.log("Pool full, retrying...");
        setTimeout(() => renameDevice(ip, name), 100);
        return;
    }
    xhr.open("POST", "http://10.7.0.1:7777/me/device");
    xhr.setRequestHeader("Content-Type", "application/json");

    var data = JSON.stringify({
        "ip": ip,
        "name": name
    });

    xhr.onreadystatechange = function() {
        if (xhr.readyState === XMLHttpRequest.DONE) {
            //isLoading = false;
            if (xhr.status === 200) {
                console.log("Success: Name for " + ip + " changed to " + name);
                WorkerScript.sendMessage({ "action": "post_name", "status": xhr.status, "ip": ip});
            } else {
                console.error("POST failed:", xhr.status);
                WorkerScript.sendMessage({ "action": "post_name", "status": xhr.status, "ip": ip});
            }
        }
    }
    xhr.send(data);
}

// POST feature switch
function switchFeature(name, value) {
    //isLoading = true;

    let xhr = getXhr();

    if (!xhr) {
        console.log("Pool full, retrying...");
        setTimeout(() => switchFeature(name, value), 100);
        return;
    }
    xhr.open("POST", "http://10.7.0.1:7777/me/feature");
    xhr.setRequestHeader("Content-Type", "application/json");

    var data = JSON.stringify({
        "name": name,
        "value": value
    });

    xhr.onreadystatechange = function() {
        if (xhr.readyState === XMLHttpRequest.DONE) {
            //isLoading = false;
            if (xhr.status === 200) {
                console.log("Success: Feature " + name + " changed to " + value);
                WorkerScript.sendMessage({ "action": "post_feature" });
            } else {
                console.error("POST failed:", xhr.status);
                WorkerScript.sendMessage({ "action": "post_feature" });
            }
        }
    }
    xhr.send(data);
}

// POST connect by server id
function connectById(iface) {
    //isLoading = true;

    let xhr = getXhr();

    if (!xhr) {
        console.log("Pool full, retrying...");
        setTimeout(() => connectById(iface), 100);
        return;
    }
    xhr.open("POST", "http://10.7.0.1:7777/me/connect_by_id");
    xhr.setRequestHeader("Content-Type", "application/json");

    var data = JSON.stringify({
        "iface": iface
    });

    xhr.onreadystatechange = function() {
        if (xhr.readyState === XMLHttpRequest.DONE) {
            //isLoading = false;
            if (xhr.status === 200) {
                console.log("Success: Changed to " + iface);
                WorkerScript.sendMessage({ "action": "post_idconnect", "status": xhr.status});
            } else {
                console.error("POST failed:", xhr.status);
                WorkerScript.sendMessage({ "action": "post_idconnect", "status": xhr.status});
            }
        }
    }
    xhr.send(data);
}

// POST aff rule to firewall
function firewallAddRule(dst, ext, local_port, port, proto) {
    //isLoading = true;

    let xhr = getXhr();

    if (!xhr) {
        console.log("Pool full, retrying...");
        setTimeout(() => firewallAddRule(dst, ext, local_port, port, proto), 100);
        return;
    }
    xhr.open("POST", "http://10.7.0.1:7777/meowrok/add");
    xhr.setRequestHeader("Content-Type", "application/json");

    var data = JSON.stringify({
        "dst": dst,
        "ext": ext,
        "local_port": local_port,
        "port": port,
        "proto": proto
    });

    xhr.onreadystatechange = function() {
        if (xhr.readyState === XMLHttpRequest.DONE) {
            //isLoading = false;
            if (xhr.status === 200) {
                console.log("Success: rule added!");
                WorkerScript.sendMessage({ "action": "post_ruleadd", "status": xhr.status});
            } else {
                console.error("POST failed:", xhr.status);
                WorkerScript.sendMessage({ "action": "post_ruleadd", "status": xhr.status});
            }
        }
    }
    xhr.send(data);
}

// POST drop rule from firewall
function firewallDropRule(dst, ext, local_port, port, proto) {
    //isLoading = true;

    let xhr = getXhr();

    if (!xhr) {
        console.log("Pool full, retrying...");
        setTimeout(() => firewallDropRule(dst, ext, local_port, port, proto), 100);
        return;
    }
    xhr.open("POST", "http://10.7.0.1:7777/meowrok/drop");
    xhr.setRequestHeader("Content-Type", "application/json");

    var data = JSON.stringify({
        "dst": dst,
        "ext": ext,
        "local_port": local_port,
        "port": port,
        "proto": proto
    });

    xhr.onreadystatechange = function() {
        if (xhr.readyState === XMLHttpRequest.DONE) {
            //isLoading = false;
            if (xhr.status === 200) {
                console.log("Success: rule dropped!");
                WorkerScript.sendMessage({ "action": "post_ruledrop", "status": xhr.status});
            } else {
                console.error("POST failed:", xhr.status);
                WorkerScript.sendMessage({ "action": "post_ruledrop", "status": xhr.status});
            }
        }
    }
    xhr.send(data);
}

WorkerScript.onMessage = function(message) {
    const actions = {
        "fetch_routes": () => fetchRoutes(message),
        "fetch_stats": () => fetchStats(message),
        "fetch_profile": () => fetchProfile(message),
        "fetch_firewall": () => fetchFirewall(message),
        "post_country": () => selectCountry(message.code, message.provider),
        "post_share": () => switchShare(message.bool),
        "post_ebalka": () => switchEbalka(message.bool, message.ip),
        "post_name": () => renameDevice(message.ip, message.name),
        "post_feature": () => switchFeature(message.name, message.value),
        "post_idconnect": () => connectById(message.iface),
        "post_ruleadd": () => firewallAddRule(message.dst, message.ext, message.local_port, message.port, message.proto),
        "post_ruledrop": () => firewallDropRule(message.dst, message.ext, message.local_port, message.port, message.proto),
        "ping": () => keepAlivePing(message)
    };

    if (actions[message.action]) {
        actions[message.action]();
    }
}