zias/stats
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

better error for buffer

Browse Source
This commit is contained in:
Carl-Gerhard Lindesvärd
2024-07-18 14:15:19 +02:00
parent ba1bd0e035
commit 7a0190c186
1 changed files with 13 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
packages/db/src/buffers/buffer.ts
View File

@@ -23,6 +23,18 @@ export type FindMany<T, R = unknown> = (
callback: (item: QueueItem<T>) => boolean callback: (item: QueueItem<T>) => boolean
) => Promise<R[]>; ) => Promise<R[]>;
const getError = (e: unknown) => {
if (e instanceof Error) {
return [
'Name: ' + e.name,
'Message: ' + e.message,
'Stack: ' + e.stack,
'Cause: ' + e.cause,
].join('\n');
}
return 'Unknown error';
};
export abstract class RedisBuffer<T> { export abstract class RedisBuffer<T> {
// constructor // constructor
public prefix = 'op:buffer'; public prefix = 'op:buffer';
@@ -98,7 +110,7 @@ export abstract class RedisBuffer<T> {
); );
const timestamp = new Date().getTime(); const timestamp = new Date().getTime();
await this.redis.hset(this.getKey(`failed:${timestamp}`), { await this.redis.hset(this.getKey(`failed:${timestamp}`), {
error: e instanceof Error ? e.message : 'Unknown error', error: getError(e),
data: JSON.stringify(queue.map((item) => item.event)), data: JSON.stringify(queue.map((item) => item.event)),
retries: 0, retries: 0,
}); });