refactoring

Resolve #7779

1 files changed, 20 insertions, 0 deletions

diff --git a/packages/backend/src/boot/worker.ts b/packages/backend/src/boot/worker.ts
new file mode 100644
index 0000000000..362fa3f26b
--- /dev/null
+++ b/packages/backend/src/boot/worker.ts
@@ -0,0 +1,20 @@
+import * as cluster from 'cluster';
+import { initDb } from '../db/postgre';
+
+/**
+ * Init worker process
+ */
+export async function workerMain() {
+	await initDb();
+
+	// start server
+	await require('../server').default();
+
+	// start job queue
+	require('../queue').default();
+
+	if (cluster.isWorker) {
+		// Send a 'ready' message to parent process
+		process.send!('ready');
+	}
+}