123 lines
4.1 KiB
TypeScript
123 lines
4.1 KiB
TypeScript
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");
|