add backend changes

server/src/service/infrastructure/bufferService.js

@@ -1,13 +1,4 @@
 const SERVICE_NAME = "BufferService";
-const TYPE_MAP = {
-	http: "checks",
-	ping: "checks",
-	port: "checks",
-	docker: "checks",
-	pagespeed: "pagespeedChecks",
-	hardware: "hardwareChecks",
-	game: "checks",
-};
 
 class BufferService {
 	static SERVICE_NAME = SERVICE_NAME;
@@ -16,17 +7,7 @@ class BufferService {
 		this.db = db;
 		this.logger = logger;
 		this.SERVICE_NAME = SERVICE_NAME;
-		this.buffers = {
-			checks: [],
-			pagespeedChecks: [],
-			hardwareChecks: [],
-		};
-		this.OPERATION_MAP = {
-			checks: this.db.checkModule.createChecks,
-			pagespeedChecks: this.db.pageSpeedCheckModule.createPageSpeedChecks,
-			hardwareChecks: this.db.hardwareCheckModule.createHardwareChecks,
-		};
-
+		this.buffer = [];
 		this.scheduleNextFlush();
 		this.logger.info({
 			message: `Buffer service initialized, flushing every ${this.BUFFER_TIMEOUT / 1000}s`,
@@ -39,9 +20,9 @@ class BufferService {
 		return BufferService.SERVICE_NAME;
 	}
 
-	addToBuffer({ check, type }) {
+	addToBuffer({ check }) {
 		try {
-			this.buffers[TYPE_MAP[type]].push(check);
+			this.buffer.push(check);
 		} catch (error) {
 			this.logger.error({
 				message: error.message,
@@ -55,7 +36,7 @@ class BufferService {
 	scheduleNextFlush() {
 		this.bufferTimer = setTimeout(async () => {
 			try {
-				await this.flushBuffers();
+				await this.flushBuffer();
 			} catch (error) {
 				this.logger.error({
 					message: `Error in flush cycle: ${error.message}`,
@@ -69,35 +50,24 @@ class BufferService {
 			}
 		}, this.BUFFER_TIMEOUT);
 	}
-	async flushBuffers() {
-		let items = 0;
-		for (const [bufferName, buffer] of Object.entries(this.buffers)) {
-			items += buffer.length;
-			const operation = this.OPERATION_MAP[bufferName];
-			if (!operation) {
-				this.logger.error({
-					message: `No operation found for ${bufferName}`,
-					service: this.SERVICE_NAME,
-					method: "flushBuffers",
-				});
-				continue;
-			}
-			try {
-				await operation(buffer);
-			} catch (error) {
-				this.logger.error({
-					message: error.message,
-					service: this.SERVICE_NAME,
-					method: "flushBuffers",
-					stack: error.stack,
-				});
-			}
-			this.buffers[bufferName] = [];
+	async flushBuffer() {
+		let items = this.buffer.length;
+
+		try {
+			await this.db.checkModule.createChecks(this.buffer);
+		} catch (error) {
+			this.logger.error({
+				message: error.message,
+				service: this.SERVICE_NAME,
+				method: "flushBuffer",
+				stack: error.stack,
+			});
 		}
+		this.buffer = [];
 		this.logger.debug({
 			message: `Flushed ${items} items`,
 			service: this.SERVICE_NAME,
-			method: "flushBuffers",
+			method: "flushBuffer",
 		});
 		items = 0;
 	}