This commit is contained in:
QuiteAFancyEmerald 2024-08-08 17:27:43 -07:00
commit b39c06d956
No known key found for this signature in database
GPG key ID: 2C9730062CD48870
3 changed files with 46 additions and 20 deletions

View file

@ -26,7 +26,7 @@ jobs:
run: npm run build run: npm run build
- name: Start server - name: Start server
run: npm run start-test-server run: npm run manual-start
- name: Test server response - name: Test server response
run: npm test run: npm test

View file

@ -12,7 +12,6 @@
"manual-start": "node run-command.mjs start", "manual-start": "node run-command.mjs start",
"kill": "node run-command.mjs stop kill", "kill": "node run-command.mjs stop kill",
"build": "node run-command.mjs build && cd lib/rammerhead && npm install && npm run build", "build": "node run-command.mjs build && cd lib/rammerhead && npm install && npm run build",
"start-test-server": "timeout 5 node backend.js; test $? -eq 124 && ( npm run manual-start & ) || exit 1",
"proxy-validator": "node proxyServiceValidator.js" "proxy-validator": "node proxyServiceValidator.js"
}, },
"keywords": [ "keywords": [

View file

@ -29,7 +29,7 @@ const shutdown = fileURLToPath(new URL('./src/.shutdown', import.meta.url));
// Run each command line argument passed after node run-command.mjs. // Run each command line argument passed after node run-command.mjs.
// Commands are defined in the switch case statement below. // Commands are defined in the switch case statement below.
for (let i = 2; i < process.argv.length; i++) commands: for (let i = 2; i < process.argv.length; i++)
switch (process.argv[i]) { switch (process.argv[i]) {
// Commmand to boot up the server. Use PM2 to run if production is true in the // Commmand to boot up the server. Use PM2 to run if production is true in the
// config file. // config file.
@ -46,26 +46,37 @@ for (let i = 2; i < process.argv.length; i++)
// This should run the server as a background process. // This should run the server as a background process.
else if (process.platform === 'win32') else if (process.platform === 'win32')
exec('START /MIN "" node backend.js', (error, stdout) => { exec('START /MIN "" node backend.js', (error, stdout) => {
if (error) throw error; if (error) {
console.error(error);
process.exitCode = 1;
}
console.log(stdout); console.log(stdout);
}); });
// The following approach (and similar approaches) will not work on Windows, // The following approach (and similar approaches) will not work on Windows,
// because exiting this program will also terminate backend.js on Windows. // because exiting this program will also terminate backend.js on Windows.
else { else {
const server = fork( const server = fork(
fileURLToPath(new URL('./backend.js', import.meta.url)), fileURLToPath(new URL("./backend.js", import.meta.url)),
{ detached: true } {
cwd: process.cwd(),
stdio: ["inherit", "inherit", "pipe", "ipc"],
detached: true
}
); );
server.stderr.on("data", stderr => {
console.error(stderr.toString());
process.exitCode = 1;
});
server.unref(); server.unref();
server.disconnect(); server.disconnect();
} }
break; break;
// Stop the server. Make a temporary file that the server will check for if told // Stop the server. Make a temporary file that the server will check for if told
// to shut down. This is done by sending a GET request to the server. // to shut down. This is done by sending a GET request to the server.
case 'stop': { case "stop": {
await writeFile(shutdown, ''); await writeFile(shutdown, "");
let timeoutId = undefined; let timeoutId, hasErrored = false;
try { try {
// Give the server 5 seconds to respond, otherwise cancel this and throw an // Give the server 5 seconds to respond, otherwise cancel this and throw an
// error to the console. The fetch request will also throw an error immediately // error to the console. The fetch request will also throw an error immediately
@ -81,18 +92,33 @@ for (let i = 2; i < process.argv.length; i++)
clearTimeout(timeoutId); clearTimeout(timeoutId);
if (response === 'Error') throw new Error('Server is unresponsive.'); if (response === 'Error') throw new Error('Server is unresponsive.');
} catch (e) { } catch (e) {
// Check if this is the error thrown by the fetch request for an unused port. // Remove the temporary shutdown file since the server didn't remove it.
// Don't print the unused port error, since nothing has actually broken.
if (e instanceof TypeError) clearTimeout(timeoutId);
else console.error(e);
await unlink(shutdown); await unlink(shutdown);
// Check if this is the error thrown by the fetch request for an unused port.
// Don't print the unused port error, since nothing has actually broken.
if (e instanceof TypeError) clearTimeout(timeoutId);
else {
console.error(e);
// Stop here unless Node will be killed later.
if (!process.argv.slice(i + 1).includes("kill"))
hasErrored = true;
}
} }
// Do not run this if Node will be killed later in this script. It will fail. // Do not run this if Node will be killed later in this script. It will fail.
if (config.production && !process.argv.slice(i + 1).includes('kill')) if (config.production && !process.argv.slice(i + 1).includes("kill"))
exec('npx pm2 stop ecosystem.config.js', (error, stdout) => { exec("npx pm2 stop ecosystem.config.js", (error, stdout) => {
if (error) throw error; if (error) {
console.error(error);
hasErrored = true;
}
console.log(stdout); console.log(stdout);
}); });
// Do not continue executing commands since the server was unable to be stopped.
// Mostly implemented to prevent duplicating Node instances with npm restart.
if (hasErrored) {
process.exitCode = 1;
break commands;
}
break; break;
} }
@ -139,4 +165,5 @@ for (let i = 2; i < process.argv.length; i++)
// No default case. // No default case.
} }
process.exitCode = 0;
process.exitCode = process.exitCode || 0;