mystiq/hydrogen-web
Archived
4
1
Fork 1
Code Issues Pull requests Projects Releases Packages Wiki Activity

emit events for rooms before invites

Browse source 
so the room is already there when removing the invite
This commit is contained in:
Bruno Windels 2021-04-23 18:04:10 +02:00
parent b77d0f75ce
commit b9f145caa4
1 changed files with 7 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

13
src/matrix/Sync.js
View file

@ -287,6 +287,13 @@ export class Sync {
_afterSync(sessionState, inviteStates, roomStates, log) { _afterSync(sessionState, inviteStates, roomStates, log) {
log.wrap("session", log => this._session.afterSync(sessionState.changes, log), log.level.Detail); log.wrap("session", log => this._session.afterSync(sessionState.changes, log), log.level.Detail);
// emit room related events after txn has been closed
for(let rs of roomStates) {
log.wrap("room", log => rs.room.afterSync(rs.changes, log), log.level.Detail);
if (rs.isNewRoom) {
this._session.addRoomAfterSync(rs.room);
}
}
// emit invite related events after txn has been closed // emit invite related events after txn has been closed
for(let is of inviteStates) { for(let is of inviteStates) {
log.wrap("invite", () => is.invite.afterSync(is.changes), log.level.Detail); log.wrap("invite", () => is.invite.afterSync(is.changes), log.level.Detail);
@ -294,12 +301,6 @@ export class Sync {
this._session.addInviteAfterSync(is.invite); this._session.addInviteAfterSync(is.invite);
} }
} }
// emit room related events after txn has been closed
for(let rs of roomStates) {
log.wrap("room", log => rs.room.afterSync(rs.changes, log), log.level.Detail);
if (rs.isNewRoom) {
this._session.addRoomAfterSync(rs.room);
}
} }
} }