From d052300ea032a7f158dde13743bf0477dc861a0c Mon Sep 17 00:00:00 2001 From: Hakan Shehu Date: Sat, 26 Oct 2024 18:18:21 +0200 Subject: [PATCH] Delete node user state on delete --- server/src/sockets/socket-connection.ts | 13 +++++++++++++ 1 file changed, 13 insertions(+) diff --git a/server/src/sockets/socket-connection.ts b/server/src/sockets/socket-connection.ts index a57d97d8..18802c72 100644 --- a/server/src/sockets/socket-connection.ts +++ b/server/src/sockets/socket-connection.ts @@ -99,12 +99,25 @@ export class SocketConnection { } } else if (messageInput.type === 'local_node_delete') { this.pendingSyncs.delete(messageInput.nodeId); + await database .deleteFrom('node_device_states') .where('device_id', '=', this.deviceId) .where('node_id', '=', messageInput.nodeId) .execute(); + const userId = this.workspaceUsers.find( + (wu) => wu.workspaceId === messageInput.workspaceId, + )?.userId; + + if (userId) { + await database + .deleteFrom('node_user_states') + .where('node_id', '=', messageInput.nodeId) + .where('user_id', '=', userId) + .execute(); + } + if (this.pendingSyncs.size === 0) { this.sendPendingChanges(); }