Merge pull request #24 from HereNotThere/sergekh2-main-sync-fix

Fix issue with sync API not advancing.
This commit is contained in:
sergekh2 2022-08-01 13:05:34 -07:00 committed by GitHub
commit 4b09cba0cc
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23

View file

@ -261,9 +261,9 @@ func (p *PDUStreamProvider) addRoomDeltaToResponse(
var pos types.StreamPosition
if _, pos, err = p.DB.PositionInTopology(ctx, mostRecentEventID); err == nil {
switch {
case r.Backwards && pos > latestPosition:
case r.Backwards && pos < latestPosition:
fallthrough
case !r.Backwards && pos < latestPosition:
case !r.Backwards && pos > latestPosition:
latestPosition = pos
}
}