(feature) log aggregated stats

backend/src/jobs.ts

@@ -2,6 +2,7 @@ import schedule from "node-schedule"
 import { AppDataSource } from "data-source"
 import { JobsService } from "services/jobs"
 import runAllTests from "services/testing/runAllTests"
+import { logAggregatedStats } from "services/logging"
 
 const main = async () => {
   const datasource = await AppDataSource.initialize()
@@ -36,6 +37,12 @@ const main = async () => {
     console.log("Finished clearing Api Trace data.")
   })
 
+  schedule.scheduleJob("0 */6 * * *", async () => {
+    console.log("Logging Aggregated Stats...")
+    await logAggregatedStats()
+    console.log("Finished Logging Aggregated Stats.")
+  })
+
   process.on("SIGINT", () => {
     schedule.gracefulShutdown().then(() => process.exit(0))
   })

backend/src/services/logging/index.ts

@@ -0,0 +1,30 @@
+import axios from "axios"
+import { AppDataSource } from "data-source"
+import { InstanceSettings } from "models"
+import { getCounts } from "services/summary/usageStats"
+
+export const logAggregatedStats = async () => {
+  const settingRepository = AppDataSource.getRepository(InstanceSettings)
+  const settingsLs = await settingRepository.find()
+  if (settingsLs.length == 0) {
+    console.log("No instance settings found...")
+    return
+  }
+  const settings = settingsLs[0]
+  const counts = await getCounts()
+  await axios({
+    url: "https://logger.metlo.com/log",
+    method: "POST",
+    data: {
+      instanceUUID: settings.uuid,
+      eventName: "instanceAggregatedStats",
+      data: {
+        numEndpoints: counts.endpointsTracked,
+        numHosts: counts.hostCount,
+        openAlerts: counts.newAlerts,
+        openHighRiskAlerts: counts.highRiskAlerts,
+        piiDataFields: counts.piiDataFields,
+      },
+    },
+  })
+}