From afbd1157c0379a856cc8df6e2e00347e54d3d796 Mon Sep 17 00:00:00 2001
From: Alex Holliday <ajhollid@gmail.com>
Date: Sun, 8 Jun 2025 09:01:30 +0800
Subject: [PATCH] add factory method

---
 server/index.js                         | 7 ++++++-
 server/service/PulseQueue/PulseQueue.js | 7 ++++++-
 2 files changed, 12 insertions(+), 2 deletions(-)

diff --git a/server/index.js b/server/index.js
index 81970ae7a..dccf77c9b 100755
--- a/server/index.js
+++ b/server/index.js
@@ -210,7 +210,12 @@ const startApp = async () => {
 		statusService,
 		notificationService,
 	});
-	const pulseQueue = new PulseQueue({ appSettings, db, pulseQueueHelper, logger });
+	const pulseQueue = await PulseQueue.create({
+		appSettings,
+		db,
+		pulseQueueHelper,
+		logger,
+	});
 
 	// Register services
 	// ServiceRegistry.register(JobQueue.SERVICE_NAME, jobQueue);
diff --git a/server/service/PulseQueue/PulseQueue.js b/server/service/PulseQueue/PulseQueue.js
index 25dcbd4d9..fd420400f 100644
--- a/server/service/PulseQueue/PulseQueue.js
+++ b/server/service/PulseQueue/PulseQueue.js
@@ -10,7 +10,12 @@ class PulseQueue {
 		this.appSettings = appSettings;
 		this.pulseQueueHelper = pulseQueueHelper;
 		this.logger = logger;
-		this.init();
+	}
+
+	static async create({ appSettings, db, pulseQueueHelper, logger }) {
+		const instance = new PulseQueue({ appSettings, db, pulseQueueHelper, logger });
+		await instance.init();
+		return instance;
 	}
 
 	// ****************************************