fix: revert no server start (#6790)

**Why**
- we want to start a server so we can allow health checks on workers
This commit is contained in:
Sebastian Rindom authored and GitHub committed 2024-03-22 14:57:34 +00:00
1 parent 7e93eda1a4
commit 4c3389e1e6
1 file changed
+26 -33
+26 -33
View File
@@ -24,47 +24,40 @@ export default async function ({ port, directory }) {
expressApp: app, expressApp: app,
}) })
const shouldStartServer =
configModule.projectConfig.worker_mode !== "worker"
let server let server
if (shouldStartServer) { const serverActivity = Logger.activity(`Creating server`)
const serverActivity = Logger.activity(`Creating server`) server = GracefulShutdownServer.create(
server = GracefulShutdownServer.create( app.listen(port, (err) => {
app.listen(port, (err) => { if (err) {
if (err) { return
return }
} Logger.success(serverActivity, `Server is ready on port: ${port}`)
Logger.success(serverActivity, `Server is ready on port: ${port}`) track("CLI_START_COMPLETED")
track("CLI_START_COMPLETED") })
)
// Handle graceful shutdown
const gracefulShutDown = () => {
server
.shutdown()
.then(() => {
Logger.info("Gracefully stopping the server.")
process.exit(0)
})
.catch((e) => {
Logger.error("Error received when shutting down the server.", e)
process.exit(1)
}) })
)
// Handle graceful shutdown
const gracefulShutDown = () => {
server
.shutdown()
.then(() => {
Logger.info("Gracefully stopping the server.")
process.exit(0)
})
.catch((e) => {
Logger.error("Error received when shutting down the server.", e)
process.exit(1)
})
}
process.on("SIGTERM", gracefulShutDown)
process.on("SIGINT", gracefulShutDown)
} else {
Logger.info("Running in worker mode, server will not be started.")
} }
process.on("SIGTERM", gracefulShutDown)
process.on("SIGINT", gracefulShutDown)
scheduleJob(CRON_SCHEDULE, () => { scheduleJob(CRON_SCHEDULE, () => {
track("PING") track("PING")
}) })
return shouldStartServer ? { dbConnection, server } : { dbConnection } return { dbConnection, server }
} catch (err) { } catch (err) {
Logger.error("Error starting server", err) Logger.error("Error starting server", err)
process.exit(1) process.exit(1)