Add cron jobs to delete incident and alert metrics older than 180 days

Common/Server/Services/IncidentService.ts

@@ -139,6 +139,9 @@ export class Service extends DatabaseService<Model> {
         isRoot: true,
       },
     });
+
+    // store incident metric
+
   }
 
   protected override async onBeforeCreate(

Worker/Jobs/Metrics/DeleteAlertMetricOlderThanXDays.ts

@@ -0,0 +1,31 @@
+import OneUptimeDate from "Common/Types/Date";
+import RunCron from "../../Utils/Cron";
+import { EVERY_DAY } from "Common/Utils/CronTime";
+import logger from "Common/Server/Utils/Logger";
+import MetricService from "Common/Server/Services/MetricService";
+import QueryHelper from "Common/Server/Types/Database/QueryHelper";
+import { ServiceType } from "Common/Models/AnalyticsModels/Metric";
+
+RunCron(
+  "Metric:DeleteAlertMetricsOlderThanXDays",
+  { schedule: EVERY_DAY, runOnStartup: true },
+  async () => {
+    const olderThanDays: number = 180; // store for 6 months.
+
+    logger.debug("Checking Metric:DeleteAlertMetricsOlderThanXDays");
+
+    logger.debug(`Deleting Alert Metrics older than ${olderThanDays} days`);
+
+    await MetricService.deleteBy({
+      query: {
+        createdAt: QueryHelper.lessThan(
+          OneUptimeDate.getSomeDaysAgo(olderThanDays),
+        ),
+        serviceType: ServiceType.Alert,
+      },
+      props: {
+        isRoot: true,
+      },
+    });
+  },
+);

Worker/Jobs/Metrics/DeleteIncidentMetricOlderThanXDays.ts

@@ -0,0 +1,31 @@
+import OneUptimeDate from "Common/Types/Date";
+import RunCron from "../../Utils/Cron";
+import { EVERY_DAY } from "Common/Utils/CronTime";
+import logger from "Common/Server/Utils/Logger";
+import MetricService from "Common/Server/Services/MetricService";
+import QueryHelper from "Common/Server/Types/Database/QueryHelper";
+import { ServiceType } from "Common/Models/AnalyticsModels/Metric";
+
+RunCron(
+  "Metric:DeleteIncidentMetricsOlderThanXDays",
+  { schedule: EVERY_DAY, runOnStartup: true },
+  async () => {
+    const olderThanDays: number = 180; // store for 6 months.
+
+    logger.debug("Checking Metric:DeleteIncidentMetricsOlderThanXDays");
+
+    logger.debug(`Deleting Incident Metrics older than ${olderThanDays} days`);
+
+    await MetricService.deleteBy({
+      query: {
+        createdAt: QueryHelper.lessThan(
+          OneUptimeDate.getSomeDaysAgo(olderThanDays),
+        ),
+        serviceType: ServiceType.Incident,
+      },
+      props: {
+        isRoot: true,
+      },
+    });
+  },
+);

Worker/Routes.ts

@@ -86,6 +86,8 @@ import "./Jobs/TelemetryMonitor/MonitorTelemetryMonitor";
 
 //Metric Jobs.
 import "./Jobs/Metrics/DeleteMonitorMetricsOlderThanXDays";
+import "./Jobs/Metrics/DeleteIncidentMetricOlderThanXDays";
+import "./Jobs/Metrics/DeleteAlertMetricOlderThanXDays";
 
 import AnalyticsTableManagement from "./Utils/AnalyticsDatabase/TableManegement";
 import RunDatabaseMigrations from "./Utils/DataMigration";