diff --git a/syncapi/storage/shared/syncserver.go b/syncapi/storage/shared/syncserver.go index 48be098fb..6fe0f4314 100644 --- a/syncapi/storage/shared/syncserver.go +++ b/syncapi/storage/shared/syncserver.go @@ -629,6 +629,7 @@ func (d *Database) addReceiptDeltaToResponse( } read.User[receipt.UserID] = eduAPI.ReceiptTS{TS: receipt.Timestamp} content[receipt.EventID] = read + res.NextBatch.ReceiptPosition++ } ev.Content, err = json.Marshal(content) if err != nil { diff --git a/syncapi/sync/requestpool.go b/syncapi/sync/requestpool.go index df3f86091..c3637f177 100644 --- a/syncapi/sync/requestpool.go +++ b/syncapi/sync/requestpool.go @@ -325,6 +325,7 @@ func (rp *RequestPool) currentSyncForUser(req syncRequest, latestPos types.Strea // Add the updates into the sync response. for _, event := range events { res.ToDevice.Events = append(res.ToDevice.Events, event.SendToDeviceEvent) + res.NextBatch.SendToDevicePosition++ } }