17497922456

Committed 05 Sep 2025 03:45PM UTC coverage: 81.355% (-0.05%) from 81.409%

Build # 17497922456

Build Type

push

github

Committed by

web-flow

Commit Message

fix: don't wait for telemetry events MCP-179 (#521)

Co-authored-by: Bianca Lisle <bianca.vianadeaguiar@mongodb.com>

Run Details

954 of 1270 branches covered (75.12%)

Branch coverage included in aggregate %.

72 of 91 new or added lines in 6 files covered. (79.12%)

1 existing line in 1 file now uncovered.

4775 of 5772 relevant lines covered (82.73%)

45.62 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

82.61

/src/telemetry/eventCache.ts

import { LRUCache } from "lru-cache";
import type { BaseEvent } from "./types.js";

/**
 * Singleton class for in-memory telemetry event caching
 * Provides a central storage for telemetry events that couldn't be sent
 * Uses LRU cache to automatically drop oldest events when limit is exceeded
 */
export class EventCache {
    private static instance: EventCache;
    private static readonly MAX_EVENTS = 1000;

    private cache: LRUCache<number, BaseEvent>;
    private nextId = 0;

    constructor() {
        this.cache = new LRUCache({
            max: EventCache.MAX_EVENTS,
            // Using FIFO eviction strategy for events
            allowStale: false,
            updateAgeOnGet: false,
        });
    }

    /**
     * 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 the number of currently cached events
     */
    public get size(): number {
        return this.cache.size;
    }

    /**
     * Gets a copy of the currently cached events along with their ids
     * @returns Array of cached BaseEvent objects
     */
    public getEvents(): { id: number; event: BaseEvent }[] {
        return Array.from(this.cache.entries()).map(([id, event]) => ({ id, event }));
    }

    /**
     * Appends new events to the cached events
     * LRU cache automatically handles dropping oldest events when limit is exceeded
     * @param events - The events to append
     */
    public appendEvents(events: BaseEvent[]): void {
        for (const event of events) {
            this.cache.set(this.nextId++, event);
        }
    }

    /**
     * Removes cached events by their ids
     */
    public removeEvents(ids: number[]): void {
        for (const id of ids) {
            this.cache.delete(id);
        }
    }
}

1	import { LRUCache } from "lru-cache";	2✔
2	import type { BaseEvent } from "./types.js";
3
4	/**
5	* Singleton class for in-memory telemetry event caching
6	* Provides a central storage for telemetry events that couldn't be sent
7	* Uses LRU cache to automatically drop oldest events when limit is exceeded
8	*/
9	export class EventCache {	2✔
10	private static instance: EventCache;
11	private static readonly MAX_EVENTS = 1000;	46✔
12
13	private cache: LRUCache<number, BaseEvent>;
14	private nextId = 0;	46✔
15
16	constructor() {	46✔
17	this.cache = new LRUCache({	37✔
18	max: EventCache.MAX_EVENTS,	37✔
19	// Using FIFO eviction strategy for events
20	allowStale: false,	37✔
21	updateAgeOnGet: false,	37✔
22	});	37✔
23	}	37✔
24
25	/**
26	* Gets the singleton instance of EventCache
27	* @returns The EventCache instance
28	*/
29	public static getInstance(): EventCache {	46✔
30	if (!EventCache.instance) {	64✔
31	EventCache.instance = new EventCache();	37✔
32	}	37✔
33	return EventCache.instance;	64✔
34	}	64✔
35
36	/**
37	* Gets the number of currently cached events
38	*/
39	public get size(): number {	46✔
40	return this.cache.size;	61✔
41	}	61✔
42
43	/**
44	* Gets a copy of the currently cached events along with their ids
45	* @returns Array of cached BaseEvent objects
46	*/
47	public getEvents(): { id: number; event: BaseEvent }[] {	46✔
48	return Array.from(this.cache.entries()).map(([id, event]) => ({ id, event }));	65✔
49	}	65✔
50
51	/**
52	* Appends new events to the cached events
53	* LRU cache automatically handles dropping oldest events when limit is exceeded
54	* @param events - The events to append
55	*/
56	public appendEvents(events: BaseEvent[]): void {	46✔
57	for (const event of events) {	×
58	this.cache.set(this.nextId++, event);	×
59	}	×
60	}	×
61
62	/**
63	* Removes cached events by their ids
64	*/
65	public removeEvents(ids: number[]): void {	46✔
66	for (const id of ids) {	65!
NEW 67	this.cache.delete(id);	×
NEW 68	}	×
69	}	65✔
70	}	46✔

mongodb-js / mongodb-mcp-server / 17497922456

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous