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

Improve interactions sending from synapse

Browse Source
This commit is contained in:
Hakan Shehu
2024-11-29 23:54:29 +01:00
parent 2e776648bd
commit e8c666bb6f
1 changed files with 5 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
apps/server/src/services/synapse-service.ts
View File

@@ -450,6 +450,7 @@ class SynapseService {
this.sendPendingTransactions(socketConnection, userId);
this.sendPendingCollaborations(socketConnection, userId);
this.sendPendingInteractions(socketConnection, userId);
}
}
}
@@ -567,6 +568,10 @@ class SynapseService {
usersToSend = collaborations.map((c) => c.user_id);
}
if (userIds.includes(event.userId) && !usersToSend.includes(event.userId)) {
usersToSend.push(event.userId);
}
for (const userId of usersToSend) {
const deviceIds = userDevices.get(userId) ?? [];
for (const deviceId of deviceIds) {