chore: fix lint and tests

Author: blva

src/telemetry/eventCache.ts

@@ -0,0 +1,46 @@
+import { BaseEvent } from "./types.js";
+
+/**
+ * Singleton class for in-memory telemetry event caching
+ * Provides a central storage for telemetry events that couldn't be sent
+ */
+export class EventCache {
+    private static instance: EventCache;
+    private events: BaseEvent[] = [];
+
+    private constructor() {}
+
+    /**
+     * Gets the singleton instance of EventCache
+     * @returns The EventCache instance
+     */
+    public static getInstance(): EventCache {
+        if (!EventCache.instance) {
+            EventCache.instance = new EventCache();
+        }
+        return EventCache.instance;
+    }
+
+    /**
+     * Gets a copy of the currently cached events
+     * @returns Array of cached BaseEvent objects
+     */
+    public getEvents(): BaseEvent[] {
+        return [...this.events];
+    }
+
+    /**
+     * Sets the cached events, replacing any existing events
+     * @param events - The events to cache
+     */
+    public setEvents(events: BaseEvent[]): void {
+        this.events = [...events];
+    }
+
+    /**
+     * Clears all cached events
+     */
+    public clearEvents(): void {
+        this.events = [];
+    }
+}

src/telemetry/telemetry.ts

@@ -91,7 +91,7 @@ export class Telemetry {
      * Falls back to caching if both attempts fail
      */
     private async emit(events: BaseEvent[]): Promise<void> {
-        const cachedEvents = await this.readCache();
+        const cachedEvents = this.readCache();
         const allEvents = [...cachedEvents, ...events];
 
         logger.debug(
@@ -102,13 +102,13 @@ export class Telemetry {
 
         const result = await this.sendEvents(this.session.apiClient, allEvents);
         if (result.success) {
-            await this.clearCache();
+            this.clearCache();
             logger.debug(mongoLogId(1_000_000), "telemetry", `Sent ${allEvents.length} events successfully`);
             return;
         }
 
         logger.warning(mongoLogId(1_000_000), "telemetry", `Error sending event to client: ${result.error}`);
-        await this.cacheEvents(allEvents);
+        this.cacheEvents(allEvents);
     }
 
     /**
@@ -130,7 +130,7 @@ export class Telemetry {
      * Reads cached events from memory
      * Returns empty array if no cache exists
      */
-    private async readCache(): Promise<BaseEvent[]> {
+    private readCache(): BaseEvent[] {
         try {
             return EventCache.getInstance().getEvents();
         } catch (error) {
@@ -146,7 +146,7 @@ export class Telemetry {
     /**
      * Caches events in memory for later sending
      */
-    private async cacheEvents(events: BaseEvent[]): Promise<void> {
+    private cacheEvents(events: BaseEvent[]): void {
         try {
             EventCache.getInstance().setEvents(events);
             logger.debug(
@@ -166,7 +166,7 @@ export class Telemetry {
     /**
      * Clears the event cache after successful sending
      */
-    private async clearCache(): Promise<void> {
+    private clearCache(): void {
         try {
             EventCache.getInstance().clearEvents();
             logger.debug(mongoLogId(1_000_000), "telemetry", "In-memory telemetry cache cleared");