diff --git a/syncapi/sync/requestpool.go b/syncapi/sync/requestpool.go index 8ef7bc16a..5a3ae8807 100644 --- a/syncapi/sync/requestpool.go +++ b/syncapi/sync/requestpool.go @@ -185,7 +185,7 @@ func (rp *RequestPool) appendAccountData( // Sync is not initial, get all account data since the latest sync dataTypes, err := rp.db.GetAccountDataInRange( req.ctx, userID, - types.StreamPosition(currentPos), types.StreamPosition(req.since.PDUPosition), + types.StreamPosition(req.since.PDUPosition), types.StreamPosition(currentPos), accountDataFilter, ) if err != nil {