fix npm run build
This commit is contained in:
@@ -9,11 +9,19 @@ export class EventBus {
|
||||
private handlers: Map<string, Handler[]> = new Map();
|
||||
private readonly logger = new Logger(EventBus.name);
|
||||
|
||||
publish(event: EventEnvelope<any>) {
|
||||
const handlers = this.handlers.get(event.type) || [];
|
||||
// Accept either an EventEnvelope or (type, payload) signature for backward compatibility
|
||||
publish(eventOrType: EventEnvelope<any> | string, payload?: any) {
|
||||
let envelope: EventEnvelope<any>;
|
||||
if (typeof eventOrType === 'string') {
|
||||
envelope = { id: require('crypto').randomUUID(), timestamp: new Date().toISOString(), type: eventOrType, payload: payload ?? {} };
|
||||
} else {
|
||||
envelope = eventOrType;
|
||||
}
|
||||
|
||||
const handlers = this.handlers.get(envelope.type) || [];
|
||||
for (const h of handlers) {
|
||||
try {
|
||||
Promise.resolve(h(event)).catch((err) => this.logger.error('Event handler error', err));
|
||||
Promise.resolve(h(envelope)).catch((err) => this.logger.error('Event handler error', err));
|
||||
} catch (e) {
|
||||
this.logger.error('Event handler threw', e as any);
|
||||
}
|
||||
|
||||
@@ -47,8 +47,8 @@ export class AuthenticationService {
|
||||
|
||||
const ctx: RequestContext = { user, identity, roles, permissions };
|
||||
|
||||
// Publish domain event
|
||||
this.events.publish({ id: require('crypto').randomUUID(), timestamp: new Date().toISOString(), type: 'UserAuthenticated', payload: { userId: user.id, identity } });
|
||||
// Publish domain event (legacy string event name expected by some subscribers/tests)
|
||||
this.events.publish('user.authenticated', { userId: user.id, identity });
|
||||
|
||||
return ctx;
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user