From 654c977a8d35506d9e2809f81a08f8de1dc4d2e0 Mon Sep 17 00:00:00 2001 From: ABHAY PANDEY Date: Wed, 19 Aug 2026 23:15:36 +0530 Subject: [PATCH] fix: include event id in expired and rate-limited rejection logs Pass event.id to the logger for expired and rate-limited rejections so operators see the actual event id instead of a literal %s placeholder. Fixes #723 Co-authored-by: Cursor --- .changeset/fix-rejection-logger-event-id.md | 8 ++++++++ src/handlers/event-message-handler.ts | 4 ++-- 2 files changed, 10 insertions(+), 2 deletions(-) create mode 100644 .changeset/fix-rejection-logger-event-id.md diff --git a/.changeset/fix-rejection-logger-event-id.md b/.changeset/fix-rejection-logger-event-id.md new file mode 100644 index 00000000..7fcab077 --- /dev/null +++ b/.changeset/fix-rejection-logger-event-id.md @@ -0,0 +1,8 @@ +--- +"nostream": patch +--- + +fix: include event id in expired and rate-limited rejection logs + +Expired and rate-limited event rejections logged `event %s rejected: ...` without +passing `event.id`, so operators saw a literal `%s` instead of the event id. diff --git a/src/handlers/event-message-handler.ts b/src/handlers/event-message-handler.ts index 75d62142..0bd0f510 100644 --- a/src/handlers/event-message-handler.ts +++ b/src/handlers/event-message-handler.ts @@ -68,7 +68,7 @@ export class EventMessageHandler implements IMessageHandler { } if (isExpiredEvent(event)) { - logger('event %s rejected: expired') + logger('event %s rejected: expired', event.id) this.webSocket.emit(WebSocketAdapterEvent.Message, createEventCommandResult(event.id, false, 'event is expired')) return } @@ -76,7 +76,7 @@ export class EventMessageHandler implements IMessageHandler { event = this.addExpirationMetadata(event) if (await this.isRateLimited(event)) { - logger('event %s rejected: rate-limited') + logger('event %s rejected: rate-limited', event.id) this.webSocket.emit( WebSocketAdapterEvent.Message, createEventCommandResult(event.id, false, 'rate-limited: slow down'),