Mirrors/colanode
1
0
Fork 0
mirror of https://github.com/colanode/colanode.git synced 2025-12-28 16:06:37 +01:00
Code Issues Packages Projects Releases Wiki Activity

Delete node user state on delete

Browse Source
This commit is contained in:
Hakan Shehu
2024-10-26 18:18:21 +02:00
parent cb5c45860b
commit d052300ea0
1 changed files with 13 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
server/src/sockets/socket-connection.ts
View File

@@ -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();
}