CalvinBackup/notesnook-sync-server_customPrivateV1
1
0
Fork 0
mirror of https://github.com/streetwriters/notesnook-sync-server.git synced 2026-02-12 11:12:44 +00:00
Code Issues Packages Projects Releases Wiki Activity

sync: fix error on monographs sync

Browse Source
This commit is contained in:
Abdullah Atta
2025-10-07 16:42:07 +05:00
committed by Abdullah Atta
parent 3a2e5f884b
commit 16ce7942be
1 changed files with 10 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
Notesnook.API/Hubs/SyncV2Hub.cs
View File

@@ -260,9 +260,15 @@ namespace Notesnook.API.Hubs
var isSyncingMonographsForFirstTime = !device.HasInitialMonographsSync; var isSyncingMonographsForFirstTime = !device.HasInitialMonographsSync;
var unsyncedMonographs = ids.Where((id) => id.EndsWith(":monograph")).ToHashSet(); var unsyncedMonographs = ids.Where((id) => id.EndsWith(":monograph")).ToHashSet();
var unsyncedMonographIds = unsyncedMonographs.Select((id) => id.Split(":")[0]).ToArray(); var unsyncedMonographIds = unsyncedMonographs.Select((id) => id.Split(":")[0]).ToArray();
Expression<Func<Monograph, bool>> filter = isResetSync || isSyncingMonographsForFirstTime FilterDefinition<Monograph> filter = isResetSync || isSyncingMonographsForFirstTime
? (m => m.UserId == userId) ? Builders<Monograph>.Filter.Eq("UserId", userId)
: (m => m.UserId == userId && unsyncedMonographIds.Contains(m.ItemId)); : Builders<Monograph>.Filter.And(
Builders<Monograph>.Filter.Eq("UserId", userId),
Builders<Monograph>.Filter.Or(
Builders<Monograph>.Filter.In("ItemId", unsyncedMonographIds),
Builders<Monograph>.Filter.In("_id", unsyncedMonographIds)
)
);
var userMonographs = await Repositories.Monographs.Collection.Find(filter).Project((m) => new MonographMetadata var userMonographs = await Repositories.Monographs.Collection.Find(filter).Project((m) => new MonographMetadata
{ {
DatePublished = m.DatePublished, DatePublished = m.DatePublished,
@@ -270,7 +276,7 @@ namespace Notesnook.API.Hubs
Password = m.Password, Password = m.Password,
SelfDestruct = m.SelfDestruct, SelfDestruct = m.SelfDestruct,
Title = m.Title, Title = m.Title,
ItemId = m.ItemId, ItemId = m.ItemId ?? m.Id.ToString(),
}).ToListAsync(); }).ToListAsync();
if (userMonographs.Count > 0 && !await Clients.Caller.SendMonographs(userMonographs).WaitAsync(TimeSpan.FromMinutes(10))) if (userMonographs.Count > 0 && !await Clients.Caller.SendMonographs(userMonographs).WaitAsync(TimeSpan.FromMinutes(10)))