From e017209d767c56e4e8fc7ab63ad9147713177860 Mon Sep 17 00:00:00 2001
From: Philipinho <16838612+Philipinho@users.noreply.github.com>
Date: Sat, 18 Apr 2026 16:32:27 +0100
Subject: [PATCH] feat(base): emit base:rows:deleted websocket event

---
 .../src/core/base/realtime/base-ws-consumers.ts      | 12 ++++++++++++
 1 file changed, 12 insertions(+)

diff --git a/apps/server/src/core/base/realtime/base-ws-consumers.ts b/apps/server/src/core/base/realtime/base-ws-consumers.ts
index 251b61f8..88371988 100644
--- a/apps/server/src/core/base/realtime/base-ws-consumers.ts
+++ b/apps/server/src/core/base/realtime/base-ws-consumers.ts
@@ -9,6 +9,7 @@ import {
   BasePropertyUpdatedEvent,
   BaseRowCreatedEvent,
   BaseRowDeletedEvent,
+  BaseRowsDeletedEvent,
   BaseRowReorderedEvent,
   BaseRowUpdatedEvent,
   BaseSchemaBumpedEvent,
@@ -63,6 +64,17 @@ export class BaseWsConsumers {
     });
   }
 
+  @OnEvent(EventName.BASE_ROWS_DELETED)
+  onRowsDeleted(e: BaseRowsDeletedEvent) {
+    this.ws.emitToBase(e.baseId, {
+      operation: 'base:rows:deleted',
+      baseId: e.baseId,
+      rowIds: e.rowIds,
+      actorId: e.actorId ?? null,
+      requestId: e.requestId ?? null,
+    });
+  }
+
   @OnEvent(EventName.BASE_ROW_REORDERED)
   onRowReordered(e: BaseRowReorderedEvent) {
     this.ws.emitToBase(e.baseId, {