go/sliding-sync
go/sliding-sync
1
0
Fork 0
mirror of https://github.com/matrix-org/sliding-sync.git synced 2025-03-10 13:37:11 +00:00
Code Issues Packages Projects Releases Wiki Activity

Remove superseded invites in the poller

Browse Source
This commit is contained in:
David Robertson 2023-10-10 18:27:45 +01:00
parent 32bc415472
commit 565854d3a7
No known key found for this signature in database
GPG Key ID: 903ECE108A39DEDD
1 changed files with 8 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
state/accumulator.go
View File

@ -297,6 +297,10 @@ func (a *Accumulator) Initialise(roomID string, state []json.RawMessage) (Initia
}
}
if err = a.invitesTable.RemoveSupersededInvites(txn, roomID, events); err != nil {
return fmt.Errorf("RemoveSupersededInvites: %w", err)
}
if err = a.spacesTable.HandleSpaceUpdates(txn, events); err != nil {
return fmt.Errorf("HandleSpaceUpdates: %s", err)
}
@ -545,6 +549,10 @@ func (a *Accumulator) Accumulate(txn *sqlx.Tx, userID, roomID string, timeline s
result.RequiresReload = currentStateRedactions > 0
}
if err = a.invitesTable.RemoveSupersededInvites(txn, roomID, postInsertEvents); err != nil {
return AccumulateResult{}, fmt.Errorf("RemoveSupersededInvites: %w", err)
}
if err = a.spacesTable.HandleSpaceUpdates(txn, postInsertEvents); err != nil {
return AccumulateResult{}, fmt.Errorf("HandleSpaceUpdates: %s", err)
}