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, {