boki/stock-bot
1
0
Fork 0
Code Issues 1 Pull requests Projects Releases Packages Wiki Activity Actions

fixed up logger error to make it better to handle in code

Browse source
This commit is contained in:
Bojan Kucera 2025-06-07 11:58:24 -04:00
parent db66687f48
commit d0bb4db042
18 changed files with 51 additions and 45 deletions
Download patch file Download diff file Expand all files Collapse all files

18
libs/event-bus/src/index.ts
View file

@ -150,7 +150,7 @@ export class EventBus extends EventEmitter {
}
}
} catch (error) {
this.logger.error(`Failed to subscribe to event: ${eventType}`, { error });
this.logger.error(`Failed to subscribe to event: ${eventType}`, error);
throw error;
}
}
@ -271,7 +271,7 @@ export class EventBus extends EventEmitter {
} catch (error) {
retryCount++;
this.logger.error(`Error processing stream message ${msgId} (attempt ${retryCount}):`, { error });
this.logger.error(`Error processing stream message ${msgId} (attempt ${retryCount}):`, error);
if (retryCount >= this.maxRetries) {
await this.moveToDeadLetterQueue(msgId, fields, streamKey, groupName, error);
@ -325,7 +325,7 @@ export class EventBus extends EventEmitter {
this.logger.debug(`Claimed and processed ${claimedMessages.length} pending messages`);
} catch (error) {
this.logger.error('Error claiming pending messages:', { error });
this.logger.error('Error claiming pending messages:', error);
}
}
@ -409,7 +409,7 @@ export class EventBus extends EventEmitter {
}
}
} catch (error) {
this.logger.error(`Failed to unsubscribe from event: ${eventType}`, { error });
this.logger.error(`Failed to unsubscribe from event: ${eventType}`, error);
}
}
}
@ -446,7 +446,7 @@ export class EventBus extends EventEmitter {
try {
return await this.redis.xinfo('STREAM', streamKey);
} catch (error) {
this.logger.error(`Failed to get stream info for: ${eventType}`, { error });
this.logger.error(`Failed to get stream info for: ${eventType}`, error);
throw error;
}
}
@ -460,7 +460,7 @@ export class EventBus extends EventEmitter {
try {
return await this.redis.xlen(streamKey);
} catch (error) {
this.logger.error(`Failed to get stream length for: ${eventType}`, { error });
this.logger.error(`Failed to get stream length for: ${eventType}`, error);
return 0;
}
}
@ -489,7 +489,7 @@ export class EventBus extends EventEmitter {
id
}));
} catch (error) {
this.logger.error(`Failed to read stream history for: ${eventType}`, { error });
this.logger.error(`Failed to read stream history for: ${eventType}`, error);
return [];
}
}
@ -503,7 +503,7 @@ export class EventBus extends EventEmitter {
try {
return await this.redis.xtrim(streamKey, 'MAXLEN', '~', maxLength);
} catch (error) {
this.logger.error(`Failed to trim stream: ${eventType}`, { error });
this.logger.error(`Failed to trim stream: ${eventType}`, error);
return 0;
}
}
@ -537,7 +537,7 @@ export class EventBus extends EventEmitter {
}
}
} catch (error) {
this.logger.error(`Error replaying event: ${event.id}`, { error });
this.logger.error(`Error replaying event: ${event.id}`, error);
}
}