Mirrors/notesnook
1
0
Fork 0
mirror of https://github.com/streetwriters/notesnook.git synced 2025-12-23 15:09:33 +01:00
Code Issues Packages Projects Releases Wiki Activity

feat: add log messages all over the place

Browse Source
This commit is contained in:
thecodrr
2022-07-19 11:16:46 +05:00
parent 36e8d9f225
commit 530a1cc625
8 changed files with 130 additions and 25 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
packages/core/api/sync/sync-queue.js
View File

@@ -1,5 +1,6 @@
import set from "../../utils/set";
import { qclone } from "qclone";
import { logger } from "../../logger";
export class SyncQueue {
/**
@@ -8,6 +9,7 @@ export class SyncQueue {
*/
constructor(storage) {
this.storage = storage;
this.logger = logger.scope("SyncQueue");
}
async new(data, syncedAt) {
@@ -24,6 +26,8 @@ export class SyncQueue {
const itemIds = set.union(syncQueue.itemIds, mapToIds(data));
const syncData = { itemIds, syncedAt };
await this.save(syncData);
this.logger.info("Ids after merge", { itemIds });
return syncData;
}
@@ -34,9 +38,11 @@ export class SyncQueue {
for (let id of ids) {
const index = itemIds.findIndex((i) => i === id);
if (index <= -1) continue;
syncQueue.itemIds.splice(index, 1);
itemIds.splice(index, 1);
}
if (syncQueue.itemIds.length <= 0) await this.save(null);
this.logger.info("Ids after dequeue", { itemIds });
if (itemIds.length <= 0) await this.save(null);
else await this.save(syncQueue);
}