mirrors/dendrite
1
0
Fork 0
mirror of https://github.com/matrix-org/dendrite.git synced 2026-01-16 18:43:10 -06:00
Code Issues Packages Projects Releases Wiki Activity

Change precedence

Browse source
This commit is contained in:
Neil Alexander 2022-10-10 15:02:34 +01:00
parent 5abb0fd369
commit 52aa054db0
No known key found for this signature in database
GPG key ID: A02A2019A2BB0944
1 changed files with 3 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
federationapi/storage/shared/storage.go
View file

@ -82,7 +82,9 @@ func (d *Database) UpdateRoom(
return err return err
} }
} }
if err = d.FederationJoinedHosts.DeleteJoinedHosts(ctx, txn, removeHosts); err != nil {
return err
}
for _, add := range addHosts { for _, add := range addHosts {
err = d.FederationJoinedHosts.InsertJoinedHosts(ctx, txn, roomID, add.MemberEventID, add.ServerName) err = d.FederationJoinedHosts.InsertJoinedHosts(ctx, txn, roomID, add.MemberEventID, add.ServerName)
if err != nil { if err != nil {
@ -90,9 +92,6 @@ func (d *Database) UpdateRoom(
} }
joinedHosts = append(joinedHosts, add) joinedHosts = append(joinedHosts, add)
} }
if err = d.FederationJoinedHosts.DeleteJoinedHosts(ctx, txn, removeHosts); err != nil {
return err
}
return nil return nil
}) })
return return