From 8908b8c6ed6cb6538fac3218d80fdad76298761f Mon Sep 17 00:00:00 2001 From: Abdullah Atta Date: Thu, 1 Jan 2026 10:35:35 +0500 Subject: [PATCH] sync: minor refactors --- Notesnook.API/Repositories/SyncItemsRepository.cs | 6 +----- Notesnook.API/Services/SyncDeviceService.cs | 2 +- Notesnook.API/Services/UserService.cs | 1 + 3 files changed, 3 insertions(+), 6 deletions(-) diff --git a/Notesnook.API/Repositories/SyncItemsRepository.cs b/Notesnook.API/Repositories/SyncItemsRepository.cs index e0f0925..ba5e0fb 100644 --- a/Notesnook.API/Repositories/SyncItemsRepository.cs +++ b/Notesnook.API/Repositories/SyncItemsRepository.cs @@ -91,11 +91,7 @@ namespace Notesnook.API.Repositories public void DeleteByUserId(string userId) { var filter = Builders.Filter.Eq("UserId", userId); - var writes = new List> - { - new DeleteManyModel(filter) - }; - dbContext.AddCommand((handle, ct) => Collection.BulkWriteAsync(handle, writes, options: null, ct)); + dbContext.AddCommand((handle, ct) => Collection.DeleteManyAsync(handle, filter, null, ct)); } public void Upsert(SyncItem item, string userId, long dateSynced) diff --git a/Notesnook.API/Services/SyncDeviceService.cs b/Notesnook.API/Services/SyncDeviceService.cs index fa71816..0a6fcf8 100644 --- a/Notesnook.API/Services/SyncDeviceService.cs +++ b/Notesnook.API/Services/SyncDeviceService.cs @@ -81,7 +81,7 @@ namespace Notesnook.API.Services if (chunk != null) { - var update = Builders.Update.PushEach(x => x.Ids, ids.Select(i => i.ToString())); + var update = Builders.Update.AddToSetEach(x => x.Ids, ids.Select(i => i.ToString())); await repositories.DeviceIdsChunks.Collection.UpdateOneAsync( Builders.Filter.Eq(x => x.Id, chunk.Id), update diff --git a/Notesnook.API/Services/UserService.cs b/Notesnook.API/Services/UserService.cs index f1e3b87..f40cd6f 100644 --- a/Notesnook.API/Services/UserService.cs +++ b/Notesnook.API/Services/UserService.cs @@ -182,6 +182,7 @@ namespace Notesnook.API.Services public async Task DeleteUserAsync(string userId) { + logger.LogInformation("Deleting user {UserId}", userId); var cc = new CancellationTokenSource(); Repositories.Notes.DeleteByUserId(userId);