From ddf7b243e46ea59c1f75b2dfb66360e820aaec45 Mon Sep 17 00:00:00 2001
From: vorotamoroz <vrtmrz@gmail.com>
Date: Sun, 15 Jun 2025 18:49:16 +0900
Subject: [PATCH] ## 0.24.28

### Fixed

- Batch Update is no longer available in LiveSync mode to avoid unexpected behaviour. (#653)
- Now compatible with Cloudflare R2 again for bucket synchronisation.
- Prevention of broken behaviour due to database connection failures added (#649).
---
 src/lib                                       |  2 +-
 src/modules/core/ModuleReplicator.ts          | 63 ++++++++++++-------
 .../ObsidianLiveSyncSettingTab.ts             |  7 ++-
 3 files changed, 46 insertions(+), 26 deletions(-)

diff --git a/src/lib b/src/lib
index d2e1e5a..3f3cf7d 160000
--- a/src/lib
+++ b/src/lib
@@ -1 +1 @@
-Subproject commit d2e1e5a51ef8a471b52601b7b4dd604fdc7cd4f9
+Subproject commit 3f3cf7d61da21372428f2b5f62bb839fad1a2928
diff --git a/src/modules/core/ModuleReplicator.ts b/src/modules/core/ModuleReplicator.ts
index 9c19ab3..944e7a8 100644
--- a/src/modules/core/ModuleReplicator.ts
+++ b/src/modules/core/ModuleReplicator.ts
@@ -244,34 +244,49 @@ Even if you choose to clean up, you will see this option again if you exit Obsid
     async loadQueuedFiles() {
         if (this.settings.suspendParseReplicationResult) return;
         if (!this.settings.isConfigured) return;
-        const kvDBKey = "queued-files";
-        // const ids = [...new Set(JSON.parse(localStorage.getItem(lsKey) || "[]"))] as string[];
-        const ids = [...new Set((await this.core.kvDB.get<string[]>(kvDBKey)) ?? [])];
-        const batchSize = 100;
-        const chunkedIds = arrayToChunkedArray(ids, batchSize);
+        try {
+            const kvDBKey = "queued-files";
+            // const ids = [...new Set(JSON.parse(localStorage.getItem(lsKey) || "[]"))] as string[];
+            const ids = [...new Set((await this.core.kvDB.get<string[]>(kvDBKey)) ?? [])];
+            const batchSize = 100;
+            const chunkedIds = arrayToChunkedArray(ids, batchSize);
 
-        // suspendParseReplicationResult is true, so we have to resume it if it is suspended.
-        if (this.replicationResultProcessor.isSuspended) {
-            this.replicationResultProcessor.resume();
-        }
-        for await (const idsBatch of chunkedIds) {
-            const ret = await this.localDatabase.allDocsRaw<EntryDoc>({
-                keys: idsBatch,
-                include_docs: true,
-                limit: 100,
-            });
-            const docs = ret.rows.filter((e) => e.doc).map((e) => e.doc) as PouchDB.Core.ExistingDocument<EntryDoc>[];
-            const errors = ret.rows.filter((e) => !e.doc && !e.value.deleted);
-            if (errors.length > 0) {
-                Logger("Some queued processes were not resurrected");
-                Logger(JSON.stringify(errors), LOG_LEVEL_VERBOSE);
+            // suspendParseReplicationResult is true, so we have to resume it if it is suspended.
+            if (this.replicationResultProcessor.isSuspended) {
+                this.replicationResultProcessor.resume();
+            }
+            for await (const idsBatch of chunkedIds) {
+                const ret = await this.localDatabase.allDocsRaw<EntryDoc>({
+                    keys: idsBatch,
+                    include_docs: true,
+                    limit: 100,
+                });
+                const docs = ret.rows
+                    .filter((e) => e.doc)
+                    .map((e) => e.doc) as PouchDB.Core.ExistingDocument<EntryDoc>[];
+                const errors = ret.rows.filter((e) => !e.doc && !e.value.deleted);
+                if (errors.length > 0) {
+                    Logger("Some queued processes were not resurrected");
+                    Logger(JSON.stringify(errors), LOG_LEVEL_VERBOSE);
+                }
+                this.replicationResultProcessor.enqueueAll(docs);
+            }
+        } catch (e) {
+            Logger(`Failed to load queued files.`, LOG_LEVEL_NOTICE);
+            Logger(e, LOG_LEVEL_VERBOSE);
+        } finally {
+            // Check again before awaiting,
+            if (this.replicationResultProcessor.isSuspended) {
+                this.replicationResultProcessor.resume();
             }
-            this.replicationResultProcessor.enqueueAll(docs);
         }
-        if (this.replicationResultProcessor.isSuspended) {
-            this.replicationResultProcessor.resume();
+        // Wait for all queued files to be processed.
+        try {
+            await this.replicationResultProcessor.waitForAllProcessed();
+        } catch (e) {
+            Logger(`Failed to wait for all queued files to be processed.`, LOG_LEVEL_NOTICE);
+            Logger(e, LOG_LEVEL_VERBOSE);
         }
-        await this.replicationResultProcessor.waitForAllProcessed();
     }
 
     replicationResultProcessor = new QueueProcessor(
diff --git a/src/modules/features/SettingDialogue/ObsidianLiveSyncSettingTab.ts b/src/modules/features/SettingDialogue/ObsidianLiveSyncSettingTab.ts
index 1f2d4d5..78d21b7 100644
--- a/src/modules/features/SettingDialogue/ObsidianLiveSyncSettingTab.ts
+++ b/src/modules/features/SettingDialogue/ObsidianLiveSyncSettingTab.ts
@@ -2090,7 +2090,12 @@ The pane also can be launched by \`P2P Replicator\` command from the Command Pal
                         .autoWireToggle("syncAfterMerge", { onUpdate: onlyOnNonLiveSync });
                 });
 
-                void addPanel(paneEl, $msg("obsidianLiveSyncSettingTab.titleUpdateThinning")).then((paneEl) => {
+                void addPanel(
+                    paneEl,
+                    $msg("obsidianLiveSyncSettingTab.titleUpdateThinning"),
+                    undefined,
+                    visibleOnly(() => !this.isConfiguredAs("syncMode", "LIVESYNC"))
+                ).then((paneEl) => {
                     paneEl.addClass("wizardHidden");
                     new Setting(paneEl).setClass("wizardHidden").autoWireToggle("batchSave");
                     new Setting(paneEl).setClass("wizardHidden").autoWireNumeric("batchSaveMinimumDelay", {