import {spawn} from "child_process";
import {getAppInfo} from "../globalUtils/appInfo.js";
import {db} from "../../database/dbclient.js";
import {serverData} from "../../database/schema/serverData.js";
import {eq, sql} from "drizzle-orm";
import {createLog} from "../services/logger/logger.js";

const updateServer = async (devApp: string, server: string) => {
    const app = await getAppInfo(devApp);
    const serverInfo = await db.select().from(serverData).where(eq(serverData.sName, server.toLowerCase()));

    const scriptPath = `${process.env.DEVFOLDER}\\server\\scripts\\update.ps1 `;
    const args = [
        "-NoProfile",
        "-ExecutionPolicy",
        "Bypass",
        "-File",
        scriptPath,
        "-username",
        process.env.ADMUSER, // needs moved to somewhere else.
        "-admpass",
        process.env.ADMPASSWORD, // needs moved to somewhere else.
        "-devFolder",
        process.env.DEVFOLDER,
        "-server",
        serverInfo[0].serverDNS,
        "-serverIP",
        serverInfo[0].idAddress,
        "-token",
        serverInfo[0].plantToken,
        "-build",
        `${process.env.DEVFOLDER}\\builds`,
        "-location",
        serverInfo[0].serverLoc,
        "-obslst",
        serverInfo[0].oldVersion,
        "-obsBuild",
        app.admConfig.oldBuild,
        ,
    ];

    return new Promise((resolve, reject) => {
        const process = spawn("powershell", args);

        //let stdout = "";
        //let stderr = "";

        // Collect stdout data
        process.stdout.on("data", (data) => {
            const output = data.toString().trim();
            createLog("info", "lst", "serverUpdater", `${output}`);
            //onData(output);
        });

        // Collect stderr data
        process.stderr.on("data", (data) => {
            const output = data.toString().trim();
            createLog("info", "lst", "serverUpdater", `${output}`);
            //onData(output);
        });

        // Handle process close
        process.on("close", async (code) => {
            if (code === 0) {
                // if (count >= servers) {
                //     //onClose(`Server completed with code: ${code}`);
                // }
                createLog("info", "lst", "serverUpdater", `${server}`);

                //update the last build.
                try {
                    await db.update(serverData).set({lastUpdated: sql`NOW()`});
                } catch (error) {
                    createLog(
                        "error",
                        "lst",
                        "serverUpdater",
                        `There was an error updating the last time the server was updated: ${error}`
                    );
                }

                resolve({success: true, code});
            } else {
                const errorMessage = `Process exited with code ${code}`;

                // if (count >= servers) {
                //     //onClose(code);
                // }

                reject(new Error(errorMessage));
            }
        });

        // Handle errors with the process itself
        process.on("error", (error) => {
            //onError(err.message);
            createLog("error", "lst", "serverUpdater", `${error}`);
            reject(error);
        });
    });
};

export async function processAllServers(devApp: string) {
    const servers = await db.select().from(serverData);

    createLog("info", "lst", "serverUpdater", `Running the update on all servers`);
    let count = 1;
    for (const server of servers) {
        try {
            const updateToServer = await updateServer(devApp, server.sName);
            createLog("info", "lst", "serverUpdater", `${server.sName} was updated.`);
            count = count + 1;

            //return {success: true, message: `${server.sName} was updated.`, data: updateToServer};
        } catch (error: any) {
            createLog("info", "lst", "serverUpdater", `Error updating ${server.sName}: ${error.message}`);
            //return {success: false, message: `Error updating ${server.sName}: ${error.message}`};
        }
    }
}

updateServer("C:\\Users\\matthes01\\Documents\\lstv2", "test");