34 lines
795 B
TypeScript
34 lines
795 B
TypeScript
import { EventEmitter } from "node:events";
|
|
|
|
export interface EventBus {
|
|
emit(channel: string, data: unknown): void;
|
|
on(channel: string, handler: (data: unknown) => void): () => void;
|
|
}
|
|
|
|
export interface EventBusController extends EventBus {
|
|
clear(): void;
|
|
}
|
|
|
|
export function createEventBus(): EventBusController {
|
|
const emitter = new EventEmitter();
|
|
return {
|
|
emit: (channel, data) => {
|
|
emitter.emit(channel, data);
|
|
},
|
|
on: (channel, handler) => {
|
|
const safeHandler = async (data: unknown) => {
|
|
try {
|
|
await handler(data);
|
|
} catch (err) {
|
|
console.error(`Event handler error (${channel}):`, err);
|
|
}
|
|
};
|
|
emitter.on(channel, safeHandler);
|
|
return () => emitter.off(channel, safeHandler);
|
|
},
|
|
clear: () => {
|
|
emitter.removeAllListeners();
|
|
},
|
|
};
|
|
}
|