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 d54b74ec..685ea270 100644 --- a/src/handlers/event-message-handler.ts +++ b/src/handlers/event-message-handler.ts @@ -69,7 +69,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 } @@ -77,7 +77,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'),