module->class

server/src/db/mongo/modules/pageSpeedCheckModule.js

@@ -1,57 +1,31 @@
-import PageSpeedCheck from "../../models/PageSpeedCheck.js";
+// import PageSpeedCheck from "../../models/PageSpeedCheck.js";
 const SERVICE_NAME = "pageSpeedCheckModule";
-/**
- * Create a PageSpeed check for a monitor
- * @async
- * @param {Object} pageSpeedCheckData
- * @param {string} pageSpeedCheckData.monitorId
- * @param {number} pageSpeedCheckData.accessibility
- * @param {number} pageSpeedCheckData.bestPractices
- * @param {number} pageSpeedCheckData.seo
- * @param {number} pageSpeedCheckData.performance
- * @returns {Promise<PageSpeedCheck>}
- * @throws {Error}
- */
-const createPageSpeedCheck = async (pageSpeedCheckData) => {
-	try {
-		const pageSpeedCheck = await new PageSpeedCheck({
-			...pageSpeedCheckData,
-		}).save();
-		return pageSpeedCheck;
-	} catch (error) {
-		error.service = SERVICE_NAME;
-		error.method = "createPageSpeedCheck";
-		throw error;
-	}
-};
-const createPageSpeedChecks = async (pageSpeedChecks) => {
-	try {
-		await PageSpeedCheck.insertMany(pageSpeedChecks, { ordered: false });
-		return true;
-	} catch (error) {
-		error.service = SERVICE_NAME;
-		error.method = "createPageSpeedCheck";
-		throw error;
-	}
-};
 
-/**
- * Delete all PageSpeed checks for a monitor
- * @async
- * @param {string} monitorId
- * @returns {number}
- * @throws {Error}
- */
-
-const deletePageSpeedChecksByMonitorId = async (monitorId) => {
-	try {
-		const result = await PageSpeedCheck.deleteMany({ monitorId });
-		return result.deletedCount;
-	} catch (error) {
-		error.service = SERVICE_NAME;
-		error.method = "deletePageSpeedChecksByMonitorId";
-		throw error;
+class PageSpeedCheckModule {
+	constructor({ PageSpeedCheck }) {
+		this.PageSpeedCheck = PageSpeedCheck;
 	}
-};
 
-export { createPageSpeedCheck, createPageSpeedChecks, deletePageSpeedChecksByMonitorId };
+	createPageSpeedChecks = async (pageSpeedChecks) => {
+		try {
+			await this.PageSpeedCheck.insertMany(pageSpeedChecks, { ordered: false });
+			return true;
+		} catch (error) {
+			error.service = SERVICE_NAME;
+			error.method = "createPageSpeedCheck";
+			throw error;
+		}
+	};
+
+	deletePageSpeedChecksByMonitorId = async (monitorId) => {
+		try {
+			const result = await this.PageSpeedCheck.deleteMany({ monitorId });
+			return result.deletedCount;
+		} catch (error) {
+			error.service = SERVICE_NAME;
+			error.method = "deletePageSpeedChecksByMonitorId";
+			throw error;
+		}
+	};
+}
+export default PageSpeedCheckModule;