diff --git a/Notesnook.API/Services/SyncDeviceService.cs b/Notesnook.API/Services/SyncDeviceService.cs index 0a6fcf8..9b7abcc 100644 --- a/Notesnook.API/Services/SyncDeviceService.cs +++ b/Notesnook.API/Services/SyncDeviceService.cs @@ -82,7 +82,7 @@ namespace Notesnook.API.Services if (chunk != null) { var update = Builders.Update.AddToSetEach(x => x.Ids, ids.Select(i => i.ToString())); - await repositories.DeviceIdsChunks.Collection.UpdateOneAsync( + await repositories.DeviceIdsChunks.Collection.WithWriteConcern(WriteConcern.W1).UpdateOneAsync( Builders.Filter.Eq(x => x.Id, chunk.Id), update ); @@ -96,11 +96,11 @@ namespace Notesnook.API.Services Key = key, Ids = [.. ids.Select(i => i.ToString())] }; - await repositories.DeviceIdsChunks.Collection.InsertOneAsync(newChunk); + await repositories.DeviceIdsChunks.Collection.WithWriteConcern(WriteConcern.W1).InsertOneAsync(newChunk); } var emptyChunksFilter = DeviceIdsChunkFilter(userId, deviceId, key) & Builders.Filter.Size(x => x.Ids, 0); - await repositories.DeviceIdsChunks.Collection.DeleteManyAsync(emptyChunksFilter); + await repositories.DeviceIdsChunks.Collection.WithWriteConcern(WriteConcern.W1).DeleteManyAsync(emptyChunksFilter); } public async Task WriteIdsAsync(string userId, string deviceId, string key, IEnumerable ids) @@ -121,7 +121,7 @@ namespace Notesnook.API.Services }; writes.Add(new InsertOneModel(newChunk)); } - await repositories.DeviceIdsChunks.Collection.BulkWriteAsync(writes); + await repositories.DeviceIdsChunks.Collection.WithWriteConcern(WriteConcern.W1).BulkWriteAsync(writes); } public async Task> FetchUnsyncedIdsAsync(string userId, string deviceId)