hoernschen/dendrite
1
0
Fork 0
mirror of https://github.com/hoernschen/dendrite.git synced 2025-08-02 14:12:47 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

re-add txn to SelectPeeks

Browse source
This commit is contained in:
Matthew Hodgson 2020-09-02 10:07:49 +01:00
parent 75b91ac9e5
commit b6cc4417cc
3 changed files with 6 additions and 6 deletions
Download patch file Download diff file Expand all files Collapse all files

6
syncapi/storage/shared/syncserver.go
View file

@ -675,7 +675,7 @@ func (d *Database) getResponseWithPDUsForCompleteSync(
}
// Add peeked rooms.
peeks, err := d.Peeks.SelectPeeks(ctx, userID, deviceID)
peeks, err := d.Peeks.SelectPeeks(ctx, txn, userID, deviceID)
if err != nil {
return
}
@ -1012,7 +1012,7 @@ func (d *Database) getStateDeltas(
// find out which rooms this user is peeking, if any.
// We do this before joins so any peeks get overwritten
peeks, err := d.Peeks.SelectPeeks(ctx, userID, device.ID)
peeks, err := d.Peeks.SelectPeeks(ctx, txn, userID, device.ID)
if err != nil {
return nil, nil, err
}
@ -1122,7 +1122,7 @@ func (d *Database) getStateDeltasForFullStateSync(
return nil, nil, err
}
peeks, err := d.Peeks.SelectPeeks(ctx, userID, device.ID)
peeks, err := d.Peeks.SelectPeeks(ctx, txn, userID, device.ID)
if err != nil {
return nil, nil, err
}