summary refs log tree commit diff
path: root/src/start.ts
diff options
context:
space:
mode:
authorFlam3rboy <34555296+Flam3rboy@users.noreply.github.com>2021-04-22 23:29:06 +0200
committerFlam3rboy <34555296+Flam3rboy@users.noreply.github.com>2021-04-22 23:29:06 +0200
commit4528a96ded3f2023d193957a95ffbd070e4cfc30 (patch)
tree8ad86c56dbd32dbd85a6d4ec9ce06d950a8fb2b3 /src/start.ts
parent:zap: :sparkles: prod multi threading (diff)
downloadserver-4528a96ded3f2023d193957a95ffbd070e4cfc30.tar.xz
prepare npm publish
Diffstat (limited to 'src/start.ts')
-rw-r--r--src/start.ts33
1 files changed, 33 insertions, 0 deletions
diff --git a/src/start.ts b/src/start.ts
new file mode 100644

index 00000000..11e15941 --- /dev/null +++ b/src/start.ts
@@ -0,0 +1,33 @@ +process.on("uncaughtException", console.error); +process.on("unhandledRejection", console.error); + +import "missing-native-js-functions"; +import { config } from "dotenv"; +config(); +import { FosscordServer } from "./Server"; +import cluster from "cluster"; +import os from "os"; +const cores = os.cpus().length; + +if (cluster.isMaster && process.env.production == "true") { + console.log(`Primary ${process.pid} is running`); + + // Fork workers. + for (let i = 0; i < cores; i++) { + cluster.fork(); + } + + cluster.on("exit", (worker, code, signal) => { + console.log(`worker ${worker.process.pid} died, restart worker`); + cluster.fork(); + }); +} else { + var port = Number(process.env.PORT); + if (isNaN(port)) port = 1000; + + const server = new FosscordServer({ port }); + server.start().catch(console.error); + + // @ts-ignore + global.server = server; +}