sseEmitter.ts RawHistoryFolder

1type SSEEventData = {
2    type: string;
3    data: unknown;
4};
5
6class CustomEventEmitter {
7    private listeners: Map<string, Array<(data: SSEEventData) => void>> = new Map();
8    private maxListeners: number = 100;
9
10    constructor() {
11        console.log('[SSE-Emitter] Initialized');
12    }
13
14    emit(event: string, data: SSEEventData) {
15        const eventListeners = this.listeners.get(event);
16        if (eventListeners) {
17            // Only log non-sensitive event types
18            if (!['userStatusUpdate', 'chatMessage'].includes(data.type)) {
19                console.log('[SSE-Emitter] Broadcasting event:', { type: data.type, listenersCount: eventListeners.length });
20            }
21            eventListeners.forEach(listener => listener(data));
22        }
23    }
24
25    addListener(event: string, listener: (data: SSEEventData) => void) {
26        if (!this.listeners.has(event)) {
27            this.listeners.set(event, []);
28        }
29        const eventListeners = this.listeners.get(event)!;
30        
31        if (eventListeners.length >= this.maxListeners) {
32            console.log(`[SSE-Emitter] Warning: Event '${event}' has exceeded the maximum number of listeners (${this.maxListeners})`);
33        }
34        
35        eventListeners.push(listener);
36        console.log('[SSE-Emitter] New listener added:', { event, totalListeners: eventListeners.length });
37    }
38
39    removeListener(event: string, listenerToRemove: (data: SSEEventData) => void) {
40        const eventListeners = this.listeners.get(event);
41        if (eventListeners) {
42            const newListeners = eventListeners.filter(listener => listener !== listenerToRemove);
43            this.listeners.set(event, newListeners);
44            console.log('[SSE-Emitter] Listener removed:', { event, remainingListeners: newListeners.length });
45        }
46    }
47
48    setMaxListeners(n: number) {
49        this.maxListeners = n;
50        console.log('[SSE-Emitter] Max listeners updated:', { newLimit: n });
51    }
52}
53
54export const sseEmitter = new CustomEventEmitter();