add global event emitter

This commit is contained in:
jeffvli
2025-10-10 11:26:17 -07:00
parent dd0586df6d
commit e67a1a6a1b
3 changed files with 108 additions and 0 deletions
+63
View File
@@ -0,0 +1,63 @@
import { ErrorHandler, EventCallback, TypedEventEmitter } from './types';
import { EventMap } from '/@/renderer/events/events';
class TypedEventEmitterImpl implements TypedEventEmitter<EventMap> {
private errorHandler: ErrorHandler | null = null;
private events: Map<string, EventCallback[]> = new Map();
emit<K extends keyof EventMap>(event: K, payload: EventMap[K]): void {
const callbacks = this.events.get(String(event));
if (callbacks) {
callbacks.forEach((callback) => {
try {
callback(payload);
} catch (error) {
this.handleError(error as Error, String(event), payload);
}
});
}
}
off<K extends keyof EventMap>(event: K, callback: EventCallback<EventMap[K]>): void {
const callbacks = this.events.get(String(event));
if (callbacks) {
const index = callbacks.indexOf(callback);
if (index > -1) {
callbacks.splice(index, 1);
}
}
}
on<K extends keyof EventMap>(event: K, callback: EventCallback<EventMap[K]>): void {
const eventKey = String(event);
if (!this.events.has(eventKey)) {
this.events.set(eventKey, []);
}
this.events.get(eventKey)!.push(callback);
}
removeAllListeners<K extends keyof EventMap>(event?: K): void {
if (event) {
// Remove specific event listeners
this.events.delete(String(event));
} else {
// Remove all listeners
this.events.clear();
}
}
setErrorHandler(handler: ErrorHandler): void {
this.errorHandler = handler;
}
private handleError(error: Error, event: string, payload: any): void {
if (this.errorHandler) {
this.errorHandler(error, event, payload);
} else {
console.error(`Event emitter error for event "${event}":`, error, payload);
}
}
}
export const eventEmitter = new TypedEventEmitterImpl();
+30
View File
@@ -0,0 +1,30 @@
import { LibraryItem } from '/@/shared/types/domain-types';
export type EventMap = {
ITEM_LIST_REFRESH: ItemListRefreshEventPayload;
ITEM_LIST_UPDATE_ITEM: ItemListUpdateItemEventPayload;
USER_FAVORITE: UserFavoriteEventPayload;
USER_RATING: UserRatingEventPayload;
};
export type ItemListRefreshEventPayload = {
key: string;
};
export type ItemListUpdateItemEventPayload = {
index: number;
item: unknown;
key: string;
};
export type UserFavoriteEventPayload = {
favorite: boolean;
id: string[];
itemType: LibraryItem;
};
export type UserRatingEventPayload = {
id: string[];
itemType: LibraryItem;
rating: null | number;
};
+15
View File
@@ -0,0 +1,15 @@
export type ErrorHandler = (error: Error, event: string, payload: any) => void;
export type EventCallback<T = any> = (payload: T) => void;
export interface TypedEventEmitter<T extends Record<string, any>> {
emit<K extends keyof T>(event: K, payload: T[K]): void;
off<K extends keyof T>(event: K, callback: EventCallback<T[K]>): void;
on<K extends keyof T>(event: K, callback: EventCallback<T[K]>): void;
removeAllListeners<K extends keyof T>(event?: K): void;
setErrorHandler(handler: ErrorHandler): void;
}