fix: Emitting schedule events to metrics exporter for traceability

steilerDev · Jul 7, 2023 · 7bb63d0 · 7bb63d0
1 parent bfec8a2
commit 7bb63d0
Show file tree

Hide file tree

Showing 2 changed files with 28 additions and 11 deletions.
diff --git a/app/src/app/event/metrics-exporter.ts b/app/src/app/event/metrics-exporter.ts
@@ -11,6 +11,7 @@ import {ErrorHandler, ERROR_EVENT, WARN_EVENT} from './error-handler.js';
 import * as fs from "fs";
 import path from "path";
 import {iCPSAppOptions} from "../factory.js";
+import {DaemonAppEvents} from "../icloud-app.js";
 
 /**
  * The InfluxLineProtocol field set type
@@ -303,9 +304,10 @@ export class MetricsExporter implements EventHandler {
                 return;
             }
 
-            // If (obj instanceof DaemonAppEvents) {
-            //     this.handleDaemonApp(obj);
-            // }
+
+            if (obj instanceof DaemonAppEvents) {
+                this.handleDaemonApp(obj);
+            }
 
             if (obj instanceof ErrorHandler) {
                 this.handleErrorHandler(obj);
@@ -505,14 +507,26 @@ export class MetricsExporter implements EventHandler {
      * Handles events emitted from the daemon app
      * @param daemon - The daemon app event emitter
      */
-    // private handleDaemonApp(daemon: DaemonAppEvents) {
-    //     daemon.on(DaemonAppEvents.EVENTS.SCHEDULED, (next: Date) => {
-    //     });
+    private handleDaemonApp(daemon: DaemonAppEvents) {
+        daemon.on(DaemonAppEvents.EVENTS.SCHEDULED, (next: Date) => {
+            this.logDataPoint(new InfluxLineProtocolPoint()
+                .addField(FIELDS.STATUS_TIME, Date.now())
+                .addField(FIELDS.STATUS.name, FIELDS.STATUS.values.SCHEDULED)
+                .addField(FIELDS.NEXT_SCHEDULE, next.getTime()));
+        });
 
-    //     daemon.on(DaemonAppEvents.EVENTS.DONE, (next: Date) => {
-    //     });
+        daemon.on(DaemonAppEvents.EVENTS.DONE, (next: Date) => {
+            this.logDataPoint(new InfluxLineProtocolPoint()
+                .addField(FIELDS.STATUS_TIME, Date.now())
+                .addField(FIELDS.STATUS.name, FIELDS.STATUS.values.SCHEDULED_SUCCESS)
+                .addField(FIELDS.NEXT_SCHEDULE, next.getTime()));
+        });
 
-    //     daemon.on(DaemonAppEvents.EVENTS.RETRY, (next: Date) => {
-    //     });
-    // }
+        daemon.on(DaemonAppEvents.EVENTS.RETRY, (next: Date) => {
+            this.logDataPoint(new InfluxLineProtocolPoint()
+                .addField(FIELDS.STATUS_TIME, Date.now())
+                .addField(FIELDS.STATUS.name, FIELDS.STATUS.values.SCHEDULED_SUCCESS)
+                .addField(FIELDS.NEXT_SCHEDULE, next.getTime()));
+        });
+    }
 }
diff --git a/docs/src/user-guides/sync-metrics.md b/docs/src/user-guides/sync-metrics.md
@@ -46,6 +46,9 @@ The following fields will be written:
     - `SYNC_COMPLETED`
     - `SYNC_RETRY`
     - `ERROR`
+    - `SCHEDULED` (no previous run)
+    - `SCHEDULED_SUCCESS` (last run successful)
+    - `SCHEDULED_FAILURE` (error during last run)
   - `assetsArchived`: The amount of assets archived during an archive operation
   - `remoteAssetsDeleted`: The amount of remote assets deleted during an archive operation (if remote delete is enabled)
   - `localAssetsLoaded`: Gives the amount of local assets loaded during a sync