matty/peertube-plugin-livechat
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Fix rebuild

Browse Source
This commit is contained in:
John Livingston 2023-09-18 15:37:12 +02:00
parent 55fa6c0623
commit 65fd49a81c
No known key found for this signature in database
GPG Key ID: B17B5640CE66CDBC
1 changed files with 10 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
server/lib/room-channel/room-channel-class.ts
View File

@ -256,13 +256,20 @@ class RoomChannel {
data[channelId].push(room.localpart) data[channelId].push(room.localpart)
} }
// This part must be done atomicly: // ************ ATOMIC PART ****************
this._readData(data) // The rebuild process can remove some rooms (for example if prosody-room-type is changed),
// So we must mark all previous rooms as to refresh:
// Now we must mark all rooms for conf update. // Now we must mark all rooms for conf update.
for (const roomJID of this.room2Channel.keys()) { for (const roomJID of this.room2Channel.keys()) {
this.roomConfToUpdate.set(roomJID, true) this.roomConfToUpdate.set(roomJID, true)
} }
// This part must be done atomicly:
this._readData(data)
// Now we must mark all rooms for conf update.
for (const roomJID of this.room2Channel.keys()) {
this.roomConfToUpdate.set(roomJID, true)
}
// ************ END OF ATOMIC PART ****************
await this.sync() // FIXME: or maybe scheduleSync ? await this.sync() // FIXME: or maybe scheduleSync ?
} }