chore: test

src/migration/noteWorker.ts

@@ -7,37 +7,30 @@ import config from "@/config";
 import { AyuskeyNextEntities } from "@/v13/models";
 import cluster from "cluster";
 
-async function main() {
-	const numWorkers = 8;
+const numWorkers = 8;
 
-	if (cluster.isPrimary) {
-		for (let i = 0; i < numWorkers; i++) {
-			cluster.fork();
-		}
-		cluster.on("exit", (worker, code, signal) => {
-			console.log(`worker ${worker.process.pid} died`);
-		});
-	} else {
-		await initDb();
-		await createConnection({
-			name: "nextDb",
-			type: "postgres",
-			host: config.db.nextDb.host,
-			port: config.db.nextDb.port,
-			username: config.db.nextDb.user,
-			password: config.db.nextDb.pass,
-			database: config.db.nextDb.db,
-			entities: AyuskeyNextEntities,
-		});
-
-		noteQueue.process(noteProcessor);
-		noteQueue.on("completed", (job) => {
-			logger.succ(`Note: ${job.data.id} の処理が完了しました`);
-		});
+if (cluster.isPrimary) {
+	for (let i = 0; i < numWorkers; i++) {
+		cluster.fork();
 	}
-}
+	cluster.on("exit", (worker, code, signal) => {
+		console.log(`worker ${worker.process.pid} died`);
+	});
+} else {
+	initDb();
+	createConnection({
+		name: "nextDb",
+		type: "postgres",
+		host: config.db.nextDb.host,
+		port: config.db.nextDb.port,
+		username: config.db.nextDb.user,
+		password: config.db.nextDb.pass,
+		database: config.db.nextDb.db,
+		entities: AyuskeyNextEntities,
+	});
 
-main().catch((e) => {
-	console.warn(e);
-	process.exit(1);
-});
+	noteQueue.process(noteProcessor);
+	noteQueue.on("completed", (job) => {
+		logger.succ(`Note: ${job.data.id} の処理が完了しました`);
+	});
+}