Software/platform
1
1
Fork 0
Code Issues 3 Pull Requests Actions Packages Projects Releases Wiki Activity

Fix naming

Browse Source
This commit is contained in:
Dominic Ferrando
2026-07-12 15:55:22 -04:00
parent 340b284189
commit 5572f9a957
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
apps/api/src/services/event-queue.ts
+3 -3
View File
@@ -135,7 +135,7 @@ export class EventQueue<G extends string, M extends Record<string, EventSpec<Jso
}; };
log.trace({ name: front.id }, "dequeuing event"); log.trace({ name: front.id }, "dequeuing event");
await this.handleEvent(front.id, front.type, front.payload); await this.processEvent(front.id, front.type, front.payload);
return front; return front;
} }
@@ -199,8 +199,8 @@ export class EventQueue<G extends string, M extends Record<string, EventSpec<Jso
.execute(); .execute();
} }
private async handleEvent(id: string, type: string, payload: JsonValue) { private async processEvent(id: string, type: string, payload: JsonValue) {
log.info({ id, payload }, "handling event"); log.info({ id, payload }, "processing event");
if (!(type in this.opt.events)) throw new Error(`Unknown event type: ${type}`); if (!(type in this.opt.events)) throw new Error(`Unknown event type: ${type}`);
const cfg = this.opt.events[type as keyof M]; const cfg = this.opt.events[type as keyof M];
try { try {