1 files changed, 4 insertions, 0 deletions

diff --git a/internal/handler/websocket/handler.go b/internal/handler/websocket/handler.go
index 8daa89f..35d0aea 100644
--- a/internal/handler/websocket/handler.go
+++ b/internal/handler/websocket/handler.go
@@ -33,6 +33,7 @@ type MetricsRecorder interface {
         DecrementSubscriptions()
         SetActiveSubscriptions(count int)
         RecordRequest(method, status string, duration float64)
+        RecordBlockedEvent(kind int32)
 }
 
 type RateLimiter interface {
@@ -302,6 +303,9 @@ func (h *Handler) handleEvent(ctx context.Context, conn *websocket.Conn, raw []j
         // Reject non-core protocol kinds (spam, ephemeral, chat)
         if !isAllowedKind(pbEvent.Kind) {
                 status = "ok"
+                if h.metrics != nil {
+                        h.metrics.RecordBlockedEvent(pbEvent.Kind)
+                }
                 h.sendOK(ctx, conn, event.ID, true, "rejected: kind not supported")
                 return nil
         }