test: share Obsidian E2E session infrastructure

releasing 0.25.80

devs.md

@@ -148,6 +148,20 @@ Hence, the new feature should be implemented as follows:
 - **Service Hub** (`src/modules/services/`): Central service registry using dependency injection
 - **Common Library** (`src/lib/`): Platform-independent sync logic, shared with other tools
 
+### Conflict Merge Policy
+
+Markdown conflict auto-merge should behave like a conservative three-way merge. The guiding rule is to merge changes when they touch non-overlapping regions, and to keep a manual conflict when the edits overlap semantically.
+
+When in doubt, prefer the safer outcome: preserve data, keep the conflict visible, and ask the user rather than silently discarding content or choosing one side.
+
+- If one side deletes a line and the other side leaves that same line unchanged, treat it as a safe deletion. The deleted line must not be reintroduced into the merged result.
+- If one side inserts new content in a different region while the other side deletes an unchanged old region, preserve the insertion and the deletion.
+- If one side deletes a line and the other side modifies that same line, keep the conflict for user resolution.
+- If both sides insert different content at the same position, keep both insertions in a deterministic order unless the surrounding deletion context indicates that they are competing replacements.
+- Avoid resolving conflicts by simply choosing the newest revision unless the user has explicitly selected that behaviour.
+
+This policy is intentionally aligned with the conflict checkboxes and compatibility settings: automatic merge should remove avoidable prompts, but it must not silently choose between overlapping user intentions.
+
 ### File Structure Conventions
 
 - **Platform-specific code**: Use `.platform.ts` suffix (replaced with `.obsidian.ts` in production builds via esbuild)

docs/settings.md

@@ -153,7 +153,7 @@ Show verbose log. Please enable when you report the logs
 Self-hosted LiveSync supports multiple remote connection profiles under **Remote Server** -> **Remote Databases**. This allows you to save and switch between multiple databases or bucket configurations in a single vault.
 
 - **➕ Add new connection**: Create a new connection profile by launching the setup dialogue.
-- **📥 Import connection**: Paste a connection string (e.g., `sls+https://...`, `sls+s3://...`, `sls+webdav://...`, `sls+p2p://...`) to import a remote configuration profile.
+- **📥 Import connection**: Paste a connection string (e.g., `sls+https://...`, `sls+s3://...`, `sls+p2p://...`) to import a remote configuration profile.
 - **🔧 Configure**: Open the setup dialogue to edit settings for the selected connection profile.
 - **✅ Activate**: Select and activate this profile as the current active remote.
 - **🗑️ Delete**: Remove this connection profile from the list.
@@ -164,12 +164,6 @@ Setting key: remoteType
 
 The active remote server type. This is automatically projected to the legacy configuration when you activate a connection profile.
 
-#### WebDAV Connection URI (Experimental)
-
-Setting key: webDAVactiveConnectionURI
-
-The active WebDAV connection URI used by experimental Journal synchronisation storage. This is configured in the **WebDAV Configuration** setup dialogue as a single `sls+webdav://...` URI. Optional query parameters include `prefix`, `useProxy=true`, and `insecure=true` for local HTTP testing. This feature is still a proof of concept for pluggable Journal storage backends and should be treated as experimental.
-
 ### 2. Notification
 
 #### Notify when the estimated remote storage size exceeds on start up

manifest.json

@@ -1,7 +1,7 @@
 {
     "id": "obsidian-livesync",
     "name": "Self-hosted LiveSync",
-    "version": "0.25.79",
+    "version": "0.25.80",
     "minAppVersion": "1.7.2",
     "description": "Community implementation of self-hosted livesync. Reflect your vault changes to some other devices immediately. Please make sure to disable other synchronize solutions to avoid content corruption or duplication.",
     "author": "vorotamoroz",

package-lock.json

@@ -1,12 +1,12 @@
 {
     "name": "obsidian-livesync",
-    "version": "0.25.79",
+    "version": "0.25.80",
     "lockfileVersion": 3,
     "requires": true,
     "packages": {
         "": {
             "name": "obsidian-livesync",
-            "version": "0.25.79",
+            "version": "0.25.80",
             "license": "MIT",
             "workspaces": [
                 "src/apps/cli",
@@ -58,6 +58,7 @@
                 "@vitest/browser": "^4.1.8",
                 "@vitest/browser-playwright": "^4.1.8",
                 "@vitest/coverage-v8": "^4.1.8",
+                "@vrtmrz/obsidian-test-session": "https://github.com/vrtmrz/fancy-kit/releases/download/consumer-preview-2026-07-10.2/vrtmrz-obsidian-test-session-0.0.0.tgz",
                 "dotenv-cli": "^11.0.0",
                 "esbuild": "0.28.1",
                 "esbuild-plugin-inline-worker": "^0.1.1",
@@ -4944,6 +4945,19 @@
                 "url": "https://opencollective.com/vitest"
             }
         },
+        "node_modules/@vrtmrz/obsidian-test-session": {
+            "version": "0.0.0",
+            "resolved": "https://github.com/vrtmrz/fancy-kit/releases/download/consumer-preview-2026-07-10.2/vrtmrz-obsidian-test-session-0.0.0.tgz",
+            "integrity": "sha512-XHWFORR8Q7vQsbKxrj8RBgpyC7DHFw5PSUXkBOKJoHnx9abgCkuQp4gYYa64RO7sOdRx/Xj799JOop+McQSqsg==",
+            "dev": true,
+            "license": "MIT",
+            "engines": {
+                "node": ">=20"
+            },
+            "peerDependencies": {
+                "playwright": ">=1.50.0"
+            }
+        },
         "node_modules/@wdio/config": {
             "version": "9.27.0",
             "resolved": "https://registry.npmjs.org/@wdio/config/-/config-9.27.0.tgz",
@@ -16210,7 +16224,7 @@
         },
         "src/apps/cli": {
             "name": "self-hosted-livesync-cli",
-            "version": "0.25.79-cli",
+            "version": "0.25.80-cli",
             "dependencies": {
                 "chokidar": "^4.0.0",
                 "minimatch": "^10.2.5",
@@ -16236,7 +16250,7 @@
         },
         "src/apps/webapp": {
             "name": "livesync-webapp",
-            "version": "0.25.79-webapp",
+            "version": "0.25.80-webapp",
             "dependencies": {
                 "octagonal-wheels": "^0.1.47"
             },
@@ -16251,7 +16265,7 @@
             }
         },
         "src/apps/webpeer": {
-            "version": "0.25.79-webpeer",
+            "version": "0.25.80-webpeer",
             "dependencies": {
                 "octagonal-wheels": "^0.1.47"
             },

package.json

@@ -1,6 +1,6 @@
 {
     "name": "obsidian-livesync",
-    "version": "0.25.79",
+    "version": "0.25.80",
     "description": "Reflect your vault changes to some other devices immediately. Please make sure to disable other synchronize solutions to avoid content corruption or duplication.",
     "main": "main.js",
     "type": "module",
@@ -64,11 +64,6 @@
         "test:docker-s3:start": "npm run test:docker-s3:up && sleep 3 && npm run test:docker-s3:init",
         "test:docker-s3:down": "npx dotenv-cli -e .env -e .test.env -- ./test/shell/minio-stop.sh",
         "test:docker-s3:stop": "npm run test:docker-s3:down",
-        "test:docker-webdav:up": "npx dotenv-cli -e .env -e .test.env -- ./test/shell/webdav-start.sh",
-        "test:docker-webdav:init": "npx dotenv-cli -e .env -e .test.env -- ./test/shell/webdav-init.sh",
-        "test:docker-webdav:start": "npm run test:docker-webdav:up && sleep 3 && npm run test:docker-webdav:init",
-        "test:docker-webdav:down": "npx dotenv-cli -e .env -e .test.env -- ./test/shell/webdav-stop.sh",
-        "test:docker-webdav:stop": "npm run test:docker-webdav:down",
         "test:docker-p2p:up": "npx dotenv-cli -e .env -e .test.env -- ./test/shell/p2p-start.sh",
         "test:docker-p2p:init": "npx dotenv-cli -e .env -e .test.env -- ./test/shell/p2p-init.sh",
         "test:docker-p2p:start": "npm run test:docker-p2p:up && sleep 3 && npm run test:docker-p2p:init",
@@ -110,6 +105,7 @@
         "@vitest/browser": "^4.1.8",
         "@vitest/browser-playwright": "^4.1.8",
         "@vitest/coverage-v8": "^4.1.8",
+        "@vrtmrz/obsidian-test-session": "https://github.com/vrtmrz/fancy-kit/releases/download/consumer-preview-2026-07-10.2/vrtmrz-obsidian-test-session-0.0.0.tgz",
         "dotenv-cli": "^11.0.0",
         "esbuild": "0.28.1",
         "esbuild-plugin-inline-worker": "^0.1.1",

src/apps/cli/commands/runCommand.unit.spec.ts

@@ -4,7 +4,7 @@ import * as os from "os";
 import * as processSetting from "@lib/API/processSetting";
 import { ConnectionStringParser } from "@lib/common/ConnectionString";
 import { configURIBase } from "@lib/common/models/shared.const";
-import { DEFAULT_SETTINGS, REMOTE_COUCHDB, REMOTE_MINIO, REMOTE_P2P, REMOTE_WEBDAV } from "@lib/common/types";
+import { DEFAULT_SETTINGS, REMOTE_COUCHDB, REMOTE_MINIO, REMOTE_P2P } from "@lib/common/types";
 import { describe, expect, it, vi, beforeEach, afterEach } from "vitest";
 import { runCommand } from "./runCommand";
 import type { CLIOptions } from "./types";
@@ -205,22 +205,6 @@ const protocolFixtures: ProtocolFixture[] = [
             expect(settings.P2P_AppID).toBe("self-hosted-livesync");
         },
     },
-    {
-        protocol: "webdav",
-        connectionString: ConnectionStringParser.serialize({
-            type: "webdav",
-            settings: {
-                webDAVactiveConnectionURI:
-                    "sls+webdav://user:pass@webdav.example.com/dav?prefix=vault%2F&headers=x-test%3A1&useProxy=true",
-            },
-        }),
-        assertProjectedFields: (settings) => {
-            expect(settings.remoteType).toBe(REMOTE_WEBDAV);
-            expect(settings.webDAVactiveConnectionURI).toBe(
-                "sls+webdav://user:pass@webdav.example.com/dav?prefix=vault%2F&headers=x-test%3A1&useProxy=true"
-            );
-        },
-    },
 ];
 
 describe("runCommand abnormal cases", () => {
@@ -580,10 +564,6 @@ describe("runCommand abnormal cases", () => {
             "p2p",
             "sls+p2p://room-abc?passphrase=pass-123&relays=wss%3A%2F%2Frelay.example&appId=self-hosted-livesync",
         ] as const,
-        [
-            "webdav",
-            "sls+webdav://user:pass@webdav.example.com/dav?prefix=vault%2F&headers=x-test%3A1&useProxy=true",
-        ] as const,
     ])("remote command round-trip works for %s", async (_protocol, initialConnStr) => {
         const core = createCoreMock();
 

src/apps/cli/package.json

@@ -1,7 +1,7 @@
 {
     "name": "self-hosted-livesync-cli",
     "private": true,
-    "version": "0.25.79-cli",
+    "version": "0.25.80-cli",
     "main": "dist/index.cjs",
     "type": "module",
     "scripts": {

src/apps/webapp/package.json

@@ -1,7 +1,7 @@
 {
     "name": "livesync-webapp",
     "private": true,
-    "version": "0.25.79-webapp",
+    "version": "0.25.80-webapp",
     "type": "module",
     "description": "Browser-based Self-hosted LiveSync using FileSystem API",
     "scripts": {

src/apps/webpeer/package.json

@@ -1,7 +1,7 @@
 {
     "name": "webpeer",
     "private": true,
-    "version": "0.25.79-webpeer",
+    "version": "0.25.80-webpeer",
     "type": "module",
     "scripts": {
         "dev": "vite",

src/features/HiddenFileSync/CmdHiddenFileSync.ts

@@ -51,6 +51,7 @@ import { EVENT_SETTING_SAVED, eventHub } from "@/common/events.ts";
 import { Semaphore } from "octagonal-wheels/concurrency/semaphore";
 import type { LiveSyncCore } from "@/main.ts";
 import { tryGetFilePath } from "@lib/common/utils.doc.ts";
+import { configureHiddenFileSyncMode } from "./configureHiddenFileSyncMode.ts";
 type SyncDirection = "push" | "pull" | "safe" | "pullForce" | "pushForce";
 
 declare global {
@@ -1832,43 +1833,35 @@ ${messageFetch}${messageOverwrite}${messageMerge}
     }
 
     async configureHiddenFileSync(mode: keyof OPTIONAL_SYNC_FEATURES) {
-        if (
-            mode != "FETCH" &&
-            mode != "OVERWRITE" &&
-            mode != "MERGE" &&
-            mode != "DISABLE" &&
-            mode != "DISABLE_HIDDEN"
-        ) {
-            return;
-        }
-
-        if (mode == "DISABLE" || mode == "DISABLE_HIDDEN") {
-            // await this.core.$allSuspendExtraSync();
-            await this.core.services.setting.applyPartial(
-                {
-                    syncInternalFiles: false,
-                },
-                true
-            );
-            // this.core.settings.syncInternalFiles = false;
-            // await this.core.saveSettings();
-            return;
-        }
-        this._log("Gathering files for enabling Hidden File Sync", LOG_LEVEL_NOTICE);
-        if (mode == "FETCH") {
-            await this.initialiseInternalFileSync("pullForce", true);
-        } else if (mode == "OVERWRITE") {
-            await this.initialiseInternalFileSync("pushForce", true);
-        } else if (mode == "MERGE") {
-            await this.initialiseInternalFileSync("safe", true);
-        }
-        await this.core.services.setting.applyPartial(
-            {
-                useAdvancedMode: true,
-                syncInternalFiles: true,
+        const result = await configureHiddenFileSyncMode(mode, {
+            disable: async () => {
+                // await this.core.$allSuspendExtraSync();
+                await this.core.services.setting.applyPartial(
+                    {
+                        syncInternalFiles: false,
+                    },
+                    true
+                );
+                // this.core.settings.syncInternalFiles = false;
+                // await this.core.saveSettings();
             },
-            true
-        );
+            enable: async () => {
+                this._log("Gathering files for enabling Hidden File Sync", LOG_LEVEL_NOTICE);
+                await this.core.services.setting.applyPartial(
+                    {
+                        useAdvancedMode: true,
+                        syncInternalFiles: true,
+                    },
+                    true
+                );
+            },
+            initialise: async (direction) => {
+                await this.initialiseInternalFileSync(direction, true);
+            },
+        });
+        if (result == "ignored" || result == "disabled") {
+            return;
+        }
         // this.plugin.settings.useAdvancedMode = true;
         // this.plugin.settings.syncInternalFiles = true;
 

src/features/HiddenFileSync/configureHiddenFileSyncMode.ts

@@ -0,0 +1,45 @@
+type HiddenFileSyncMode = "FETCH" | "OVERWRITE" | "MERGE" | "DISABLE" | "DISABLE_HIDDEN";
+type HiddenFileSyncDirection = "pullForce" | "pushForce" | "safe";
+
+type ConfigureHiddenFileSyncHandlers = {
+    disable: () => Promise<void>;
+    enable: () => Promise<void>;
+    initialise: (direction: HiddenFileSyncDirection) => Promise<void>;
+};
+
+export type ConfigureHiddenFileSyncResult = "ignored" | "disabled" | "enabled";
+
+function getInitialiseDirection(mode: keyof OPTIONAL_SYNC_FEATURES): HiddenFileSyncDirection | false {
+    if (mode == "FETCH") return "pullForce";
+    if (mode == "OVERWRITE") return "pushForce";
+    if (mode == "MERGE") return "safe";
+    return false;
+}
+
+function isDisableMode(mode: keyof OPTIONAL_SYNC_FEATURES): boolean {
+    return mode == "DISABLE" || mode == "DISABLE_HIDDEN";
+}
+
+function isHiddenFileSyncMode(mode: keyof OPTIONAL_SYNC_FEATURES): mode is HiddenFileSyncMode {
+    return mode == "FETCH" || mode == "OVERWRITE" || mode == "MERGE" || isDisableMode(mode);
+}
+
+export async function configureHiddenFileSyncMode(
+    mode: keyof OPTIONAL_SYNC_FEATURES,
+    handlers: ConfigureHiddenFileSyncHandlers
+): Promise<ConfigureHiddenFileSyncResult> {
+    if (!isHiddenFileSyncMode(mode)) {
+        return "ignored";
+    }
+    if (isDisableMode(mode)) {
+        await handlers.disable();
+        return "disabled";
+    }
+    const direction = getInitialiseDirection(mode);
+    if (direction === false) {
+        return "ignored";
+    }
+    await handlers.enable();
+    await handlers.initialise(direction);
+    return "enabled";
+}

src/features/HiddenFileSync/configureHiddenFileSyncMode.unit.spec.ts

@@ -0,0 +1,47 @@
+import { describe, expect, it, vi } from "vitest";
+
+import { configureHiddenFileSyncMode } from "./configureHiddenFileSyncMode.ts";
+
+describe("configureHiddenFileSyncMode", () => {
+    it.each([
+        ["FETCH", "pullForce"],
+        ["OVERWRITE", "pushForce"],
+        ["MERGE", "safe"],
+    ] as const)("enables hidden file sync before initialising %s", async (mode, direction) => {
+        const calls: string[] = [];
+
+        const result = await configureHiddenFileSyncMode(mode, {
+            disable: vi.fn(async () => {
+                calls.push("disable");
+            }),
+            enable: vi.fn(async () => {
+                calls.push("enable");
+            }),
+            initialise: vi.fn(async (actualDirection) => {
+                calls.push(`init:${actualDirection}`);
+            }),
+        });
+
+        expect(result).toBe("enabled");
+        expect(calls).toEqual(["enable", `init:${direction}`]);
+    });
+
+    it.each(["DISABLE", "DISABLE_HIDDEN"] as const)("disables hidden file sync immediately for %s", async (mode) => {
+        const calls: string[] = [];
+
+        const result = await configureHiddenFileSyncMode(mode, {
+            disable: vi.fn(async () => {
+                calls.push("disable");
+            }),
+            enable: vi.fn(async () => {
+                calls.push("enable");
+            }),
+            initialise: vi.fn(async (direction) => {
+                calls.push(`init:${direction}`);
+            }),
+        });
+
+        expect(result).toBe("disabled");
+        expect(calls).toEqual(["disable"]);
+    });
+});

src/modules/core/ModuleReplicatorCouchDB.ts

@@ -1,5 +1,5 @@
 import { fireAndForget } from "octagonal-wheels/promises";
-import { REMOTE_P2P, isJournalRemoteType, type RemoteDBSettings } from "@lib/common/types";
+import { REMOTE_MINIO, REMOTE_P2P, type RemoteDBSettings } from "@lib/common/types";
 import { LiveSyncCouchDBReplicator } from "@lib/replication/couchdb/LiveSyncReplicator";
 import type { LiveSyncAbstractReplicator } from "@lib/replication/LiveSyncAbstractReplicator";
 import { AbstractModule } from "@/modules/AbstractModule";
@@ -9,7 +9,7 @@ export class ModuleReplicatorCouchDB extends AbstractModule {
     _anyNewReplicator(settingOverride: Partial<RemoteDBSettings> = {}): Promise<LiveSyncAbstractReplicator | false> {
         const settings = { ...this.settings, ...settingOverride };
         // If new remote types were added, add them here. Do not use `REMOTE_COUCHDB` directly for the safety valve.
-        if (isJournalRemoteType(settings.remoteType) || settings.remoteType == REMOTE_P2P) {
+        if (settings.remoteType == REMOTE_MINIO || settings.remoteType == REMOTE_P2P) {
             return Promise.resolve(false);
         }
         return Promise.resolve(new LiveSyncCouchDBReplicator(this.core));
@@ -17,7 +17,7 @@ export class ModuleReplicatorCouchDB extends AbstractModule {
     _everyAfterResumeProcess(): Promise<boolean> {
         if (this.services.appLifecycle.isSuspended()) return Promise.resolve(true);
         if (!this.services.appLifecycle.isReady()) return Promise.resolve(true);
-        if (!isJournalRemoteType(this.settings.remoteType) && this.settings.remoteType != REMOTE_P2P) {
+        if (this.settings.remoteType != REMOTE_MINIO && this.settings.remoteType != REMOTE_P2P) {
             const LiveSyncEnabled = this.settings.liveSync;
             const continuous = LiveSyncEnabled;
             const eventualOnStart = !LiveSyncEnabled && this.settings.syncOnStart;

src/modules/core/ModuleReplicatorMinIO.ts

@@ -1,4 +1,4 @@
-import { isJournalRemoteType, type RemoteDBSettings } from "@lib/common/types";
+import { REMOTE_MINIO, type RemoteDBSettings } from "@lib/common/types";
 import { LiveSyncJournalReplicator } from "@lib/replication/journal/LiveSyncJournalReplicator";
 import type { LiveSyncAbstractReplicator } from "@lib/replication/LiveSyncAbstractReplicator";
 import type { LiveSyncCore } from "@/main";
@@ -7,7 +7,7 @@ import { AbstractModule } from "@/modules/AbstractModule";
 export class ModuleReplicatorMinIO extends AbstractModule {
     _anyNewReplicator(settingOverride: Partial<RemoteDBSettings> = {}): Promise<LiveSyncAbstractReplicator | false> {
         const settings = { ...this.settings, ...settingOverride };
-        if (isJournalRemoteType(settings.remoteType)) {
+        if (settings.remoteType == REMOTE_MINIO) {
             return Promise.resolve(new LiveSyncJournalReplicator(this.core));
         }
         return Promise.resolve(false);

src/modules/features/SettingDialogue/ObsidianLiveSyncSettingTab.ts

@@ -12,7 +12,6 @@ import {
     LEVEL_ADVANCED,
     LEVEL_EDGE_CASE,
     REMOTE_P2P,
-    isJournalRemoteType,
 } from "@lib/common/types.ts";
 import { delay, isObjectDifferent, sizeToHumanReadable } from "@lib/common/utils.ts";
 import { versionNumberString2Number } from "@lib/string_and_binary/convert.ts";
@@ -65,7 +64,7 @@ import { panePatches } from "./PanePatches.ts";
 import { paneMaintenance } from "./PaneMaintenance.ts";
 import { compatGlobal } from "@lib/common/coreEnvFunctions.ts";
 import { JournalSyncCore } from "@lib/replication/journal/JournalSyncCore.js";
-import { createJournalStorageAdapter } from "@lib/replication/journal/objectstore/JournalStorageAdapterFactory.js";
+import { MinioStorageAdapter } from "@lib/replication/journal/objectstore/MinioStorageAdapter.js";
 
 // For creating a document
 // const toc = new Set<string>();
@@ -531,10 +530,6 @@ export class ObsidianLiveSyncSettingTab extends PluginSettingTab {
         ({
             visibility: this.isConfiguredAs("remoteType", REMOTE_MINIO),
         }) as OnUpdateResult;
-    onlyOnJournalSync = () =>
-        ({
-            visibility: isJournalRemoteType(this.editingSettings.remoteType),
-        }) as OnUpdateResult;
     onlyOnOnlyP2P = () =>
         ({
             visibility: this.isConfiguredAs("remoteType", REMOTE_P2P),
@@ -542,14 +537,11 @@ export class ObsidianLiveSyncSettingTab extends PluginSettingTab {
     onlyOnCouchDBOrMinIO = () =>
         ({
             visibility:
-                this.isConfiguredAs("remoteType", REMOTE_COUCHDB) ||
-                isJournalRemoteType(this.editingSettings.remoteType),
+                this.isConfiguredAs("remoteType", REMOTE_COUCHDB) || this.isConfiguredAs("remoteType", REMOTE_MINIO),
         }) as OnUpdateResult;
     // E2EE Function
     checkWorkingPassphrase = async (): Promise<boolean> => {
-        if (isJournalRemoteType(this.editingSettings.remoteType)) {
-            return true;
-        }
+        if (this.editingSettings.remoteType == REMOTE_MINIO) return true;
 
         const settingForCheck: RemoteDBSettings = {
             ...this.editingSettings,
@@ -864,7 +856,7 @@ export class ObsidianLiveSyncSettingTab extends PluginSettingTab {
             this.core.settings,
             this.core.simpleStore,
             this.core,
-            createJournalStorageAdapter(this.core.settings, this.core)
+            new MinioStorageAdapter(this.core.settings, this.core)
         );
     }
     async resetRemoteBucket() {

src/modules/features/SettingDialogue/PaneMaintenance.ts

@@ -163,7 +163,7 @@ export function paneMaintenance(
                         Logger(`Journal received history has been cleared.`, LOG_LEVEL_NOTICE);
                     })
             )
-            .addOnUpdate(this.onlyOnJournalSync);
+            .addOnUpdate(this.onlyOnMinIO);
 
         new Setting(paneEl)
             .setName("Reset journal sent history")
@@ -185,7 +185,7 @@ export function paneMaintenance(
                         Logger(`Journal sent history has been cleared.`, LOG_LEVEL_NOTICE);
                     })
             )
-            .addOnUpdate(this.onlyOnJournalSync);
+            .addOnUpdate(this.onlyOnMinIO);
     });
     void addPanel(paneEl, "Garbage Collection V3 (Beta)", (e) => e, this.onlyOnP2POrCouchDB).then((paneEl) => {
         new Setting(paneEl)
@@ -336,7 +336,7 @@ export function paneMaintenance(
                         Logger(`Journal exchange history has been cleared.`, LOG_LEVEL_NOTICE);
                     })
             )
-            .addOnUpdate(this.onlyOnJournalSync);
+            .addOnUpdate(this.onlyOnMinIO);
 
         new Setting(paneEl)
             .setName("Purge all journal counter")
@@ -351,7 +351,7 @@ export function paneMaintenance(
                         Logger(`Journal download/upload cache has been cleared.`, LOG_LEVEL_NOTICE);
                     })
             )
-            .addOnUpdate(this.onlyOnJournalSync);
+            .addOnUpdate(this.onlyOnMinIO);
 
         new Setting(paneEl)
             .setName("Fresh Start Wipe")
@@ -374,7 +374,7 @@ export function paneMaintenance(
                         Logger(`Deleted all data on remote server`, LOG_LEVEL_NOTICE);
                     })
             )
-            .addOnUpdate(this.onlyOnJournalSync);
+            .addOnUpdate(this.onlyOnMinIO);
     });
 
     void addPanel(paneEl, "Reset").then((paneEl) => {

src/modules/features/SettingDialogue/PaneRemoteConfig.ts

@@ -2,7 +2,6 @@ import {
     REMOTE_COUCHDB,
     REMOTE_MINIO,
     REMOTE_P2P,
-    REMOTE_WEBDAV,
     DEFAULT_SETTINGS,
     LOG_LEVEL_NOTICE,
     type ObsidianLiveSyncSettings,
@@ -34,9 +33,7 @@ import SetupRemote from "@/modules/features/SetupWizard/dialogs/SetupRemote.svel
 import SetupRemoteCouchDB from "@/modules/features/SetupWizard/dialogs/SetupRemoteCouchDB.svelte";
 import SetupRemoteBucket from "@/modules/features/SetupWizard/dialogs/SetupRemoteBucket.svelte";
 import SetupRemoteP2P from "@/modules/features/SetupWizard/dialogs/SetupRemoteP2P.svelte";
-import SetupRemoteWebDAV from "@/modules/features/SetupWizard/dialogs/SetupRemoteWebDAV.svelte";
 import { syncActivatedRemoteSettings } from "./remoteConfigBuffer.ts";
-import { getRemoteConfigurationDescription } from "./remoteConfigDisplay.ts";
 
 function getSettingsFromEditingSettings(editingSettings: AllSettings): ObsidianLiveSyncSettings {
     const workObj = { ...editingSettings } as ObsidianLiveSyncSettings;
@@ -72,9 +69,6 @@ function serializeRemoteConfiguration(settings: ObsidianLiveSyncSettings): strin
     if (settings.remoteType === REMOTE_P2P) {
         return ConnectionStringParser.serialize({ type: "p2p", settings });
     }
-    if (settings.remoteType === REMOTE_WEBDAV) {
-        return ConnectionStringParser.serialize({ type: "webdav", settings });
-    }
     return ConnectionStringParser.serialize({ type: "couchdb", settings });
 }
 
@@ -98,14 +92,6 @@ function suggestRemoteConfigurationName(parsed: RemoteConfigurationResult): stri
     if (parsed.type === "s3") {
         return `S3 ${parsed.settings.bucket || parsed.settings.endpoint}`;
     }
-    if (parsed.type === "webdav") {
-        try {
-            const url = new URL(parsed.settings.webDAVactiveConnectionURI.replace(/^sls\+webdav:/, "https:"));
-            return `WebDAV ${url.host}`;
-        } catch {
-            return "Imported WebDAV";
-        }
-    }
     return `P2P ${parsed.settings.P2P_roomID || "Remote"}`;
 }
 
@@ -212,7 +198,7 @@ export function paneRemoteConfig(
             };
             const runRemoteSetup = async (
                 baseSettings: ObsidianLiveSyncSettings,
-                remoteType?: typeof REMOTE_COUCHDB | typeof REMOTE_MINIO | typeof REMOTE_P2P | typeof REMOTE_WEBDAV
+                remoteType?: typeof REMOTE_COUCHDB | typeof REMOTE_MINIO | typeof REMOTE_P2P
             ): Promise<ObsidianLiveSyncSettings | false> => {
                 const setupManager = this.core.getModule(SetupManager);
                 const dialogManager = setupManager.dialogManager;
@@ -224,13 +210,7 @@ export function paneRemoteConfig(
                         return false;
                     }
                     targetRemoteType =
-                        method === "bucket"
-                            ? REMOTE_MINIO
-                            : method === "p2p"
-                              ? REMOTE_P2P
-                              : method === "webdav"
-                                ? REMOTE_WEBDAV
-                                : REMOTE_COUCHDB;
+                        method === "bucket" ? REMOTE_MINIO : method === "p2p" ? REMOTE_P2P : REMOTE_COUCHDB;
                 }
 
                 if (targetRemoteType === REMOTE_MINIO) {
@@ -249,14 +229,6 @@ export function paneRemoteConfig(
                     return { ...baseSettings, ...p2pConf, remoteType: REMOTE_P2P };
                 }
 
-                if (targetRemoteType === REMOTE_WEBDAV) {
-                    const webDAVConf = await dialogManager.openWithExplicitCancel(SetupRemoteWebDAV, baseSettings);
-                    if (webDAVConf === "cancelled" || typeof webDAVConf !== "object") {
-                        return false;
-                    }
-                    return { ...baseSettings, ...webDAVConf, remoteType: REMOTE_WEBDAV };
-                }
-
                 const couchConf = await dialogManager.openWithExplicitCancel(SetupRemoteCouchDB, baseSettings);
                 if (couchConf === "cancelled" || typeof couchConf !== "object") {
                     return false;
@@ -359,7 +331,7 @@ export function paneRemoteConfig(
                 for (const config of Object.values(configs)) {
                     const row = new Setting(listContainer)
                         .setName(config.name)
-                        .setDesc(getRemoteConfigurationDescription(config.uri));
+                        .setDesc(config.uri.split("@").pop() || ""); // Show host part for privacy
 
                     if (config.id === this.editingSettings.activeConfigurationId) {
                         row.nameEl.addClass("sls-active-remote-name");
@@ -384,8 +356,6 @@ export function paneRemoteConfig(
                                 workSettings.remoteType = REMOTE_COUCHDB;
                             } else if (parsed.type === "s3") {
                                 workSettings.remoteType = REMOTE_MINIO;
-                            } else if (parsed.type === "webdav") {
-                                workSettings.remoteType = REMOTE_WEBDAV;
                             } else {
                                 workSettings.remoteType = REMOTE_P2P;
                             }
@@ -496,8 +466,6 @@ export function paneRemoteConfig(
                                             workSettings.remoteType = REMOTE_COUCHDB;
                                         } else if (parsed.type === "s3") {
                                             workSettings.remoteType = REMOTE_MINIO;
-                                        } else if (parsed.type === "webdav") {
-                                            workSettings.remoteType = REMOTE_WEBDAV;
                                         } else {
                                             workSettings.remoteType = REMOTE_P2P;
                                         }

src/modules/features/SettingDialogue/PaneRemoteConfig.unit.spec.ts

@@ -1,12 +0,0 @@
-import { describe, expect, it } from "vitest";
-import { getRemoteConfigurationDescription } from "./remoteConfigDisplay";
-
-describe("getRemoteConfigurationDescription", () => {
-    it("should mask credentials and query parameters in WebDAV connection strings", () => {
-        expect(
-            getRemoteConfigurationDescription(
-                "sls+webdav://user:pass@example.com/dav?prefix=vault%2F&headers=Authorization%3A%20Bearer%20token"
-            )
-        ).toBe("https://example.com/dav");
-    });
-});

src/modules/features/SettingDialogue/remoteConfigBuffer.ts

@@ -1,9 +1,4 @@
-import {
-    pickBucketSyncSettings,
-    pickCouchDBSyncSettings,
-    pickP2PSyncSettings,
-    pickWebDAVSyncSettings,
-} from "@lib/common/utils.ts";
+import { pickBucketSyncSettings, pickCouchDBSyncSettings, pickP2PSyncSettings } from "@lib/common/utils.ts";
 import type { ObsidianLiveSyncSettings } from "@lib/common/types.ts";
 
 // Keep the setting dialogue buffer aligned with the current core settings before persisting other dirty keys.
@@ -18,6 +13,5 @@ export function syncActivatedRemoteSettings(
         ...pickBucketSyncSettings(source),
         ...pickCouchDBSyncSettings(source),
         ...pickP2PSyncSettings(source),
-        ...pickWebDAVSyncSettings(source),
     });
 }

src/modules/features/SettingDialogue/remoteConfigBuffer.unit.spec.ts

@@ -1,5 +1,5 @@
 import { describe, expect, it } from "vitest";
-import { DEFAULT_SETTINGS, REMOTE_COUCHDB, REMOTE_MINIO, REMOTE_WEBDAV } from "@lib/common/types";
+import { DEFAULT_SETTINGS, REMOTE_COUCHDB, REMOTE_MINIO } from "@lib/common/types";
 import { syncActivatedRemoteSettings } from "./remoteConfigBuffer";
 
 describe("syncActivatedRemoteSettings", () => {
@@ -80,25 +80,4 @@ describe("syncActivatedRemoteSettings", () => {
         expect(target.couchDB_PASSWORD).toBe("current-pass");
         expect(target.couchDB_DBNAME).toBe("current-db");
     });
-
-    it("should copy active WebDAV connection URI into the editing buffer", () => {
-        const target = {
-            ...DEFAULT_SETTINGS,
-            remoteType: REMOTE_COUCHDB,
-            activeConfigurationId: "old-remote",
-            webDAVactiveConnectionURI: "",
-        };
-        const source = {
-            ...DEFAULT_SETTINGS,
-            remoteType: REMOTE_WEBDAV,
-            activeConfigurationId: "remote-webdav",
-            webDAVactiveConnectionURI: "sls+webdav://user:pass@example.com/dav?prefix=vault%2F",
-        };
-
-        syncActivatedRemoteSettings(target, source);
-
-        expect(target.remoteType).toBe(REMOTE_WEBDAV);
-        expect(target.activeConfigurationId).toBe("remote-webdav");
-        expect(target.webDAVactiveConnectionURI).toBe("sls+webdav://user:pass@example.com/dav?prefix=vault%2F");
-    });
 });

src/modules/features/SettingDialogue/remoteConfigDisplay.ts

@@ -1,29 +0,0 @@
-import { ConnectionStringParser } from "@lib/common/ConnectionString.ts";
-
-export function getRemoteConfigurationDescription(uri: string): string {
-    try {
-        const parsed = ConnectionStringParser.parse(uri);
-        if (parsed.type === "couchdb") {
-            const url = new URL(parsed.settings.couchDB_URI);
-            url.username = "";
-            url.password = "";
-            url.search = "";
-            url.hash = "";
-            return url.toString();
-        }
-        if (parsed.type === "s3") {
-            return `${parsed.settings.endpoint.replace(/\/+$/g, "")}/${parsed.settings.bucket}`;
-        }
-        if (parsed.type === "webdav") {
-            const url = new URL(parsed.settings.webDAVactiveConnectionURI.replace(/^sls\+webdav:/, "https:"));
-            url.username = "";
-            url.password = "";
-            url.search = "";
-            url.hash = "";
-            return url.toString();
-        }
-        return `P2P ${parsed.settings.P2P_roomID || "Remote"}`;
-    } catch {
-        return uri.split("@").pop()?.split("?")[0] || "";
-    }
-}

src/modules/features/SetupManager.ts

@@ -4,14 +4,12 @@ import {
     type EncryptionSettings,
     type ObsidianLiveSyncSettings,
     type P2PSyncSetting,
-    type WebDAVSyncSetting,
     DEFAULT_SETTINGS,
     LOG_LEVEL_NOTICE,
     LOG_LEVEL_VERBOSE,
     REMOTE_COUCHDB,
     REMOTE_MINIO,
     REMOTE_P2P,
-    REMOTE_WEBDAV,
 } from "@lib/common/types.ts";
 import { isObjectDifferent } from "@lib/common/utils.ts";
 import Intro from "./SetupWizard/dialogs/Intro.svelte";
@@ -26,7 +24,6 @@ import SetupRemote from "./SetupWizard/dialogs/SetupRemote.svelte";
 import SetupRemoteCouchDB from "./SetupWizard/dialogs/SetupRemoteCouchDB.svelte";
 import SetupRemoteBucket from "./SetupWizard/dialogs/SetupRemoteBucket.svelte";
 import SetupRemoteP2P from "./SetupWizard/dialogs/SetupRemoteP2P.svelte";
-import SetupRemoteWebDAV from "./SetupWizard/dialogs/SetupRemoteWebDAV.svelte";
 import SetupRemoteE2EE from "./SetupWizard/dialogs/SetupRemoteE2EE.svelte";
 import { decodeSettingsFromQRCodeData } from "@lib/API/processSetting.ts";
 import { AbstractModule } from "@/modules/AbstractModule.ts";
@@ -41,7 +38,6 @@ import type {
     SetupRemoteE2EEResultType,
     SetupRemoteP2PResultType,
     SetupRemoteResultType,
-    SetupRemoteWebDAVResultType,
     UseSetupURIResultType,
 } from "./SetupWizard/dialogs/setupDialogTypes.ts";
 
@@ -206,33 +202,6 @@ export class SetupManager extends AbstractModule {
         return await this.onConfirmApplySettingsFromWizard(newSetting, userMode, activate);
     }
 
-    /**
-     * Handles manual setup for WebDAV-compatible storage.
-     * @param userMode
-     * @param currentSetting
-     * @param activate Whether to activate WebDAV as remote type
-     * @returns Promise that resolves to true if setup completed successfully, false otherwise
-     */
-    async onWebDAVManualSetup(
-        userMode: UserMode,
-        currentSetting: ObsidianLiveSyncSettings,
-        activate = true
-    ): Promise<boolean> {
-        const webDAVConf = await this.dialogManager.openWithExplicitCancel<
-            SetupRemoteWebDAVResultType,
-            WebDAVSyncSetting
-        >(SetupRemoteWebDAV, currentSetting);
-        if (webDAVConf === "cancelled") {
-            this._log("Manual configuration cancelled.", LOG_LEVEL_NOTICE);
-            return await this.onOnboard(userMode);
-        }
-        const newSetting = { ...currentSetting, ...webDAVConf } as ObsidianLiveSyncSettings;
-        if (activate) {
-            newSetting.remoteType = REMOTE_WEBDAV;
-        }
-        return await this.onConfirmApplySettingsFromWizard(newSetting, userMode, activate);
-    }
-
     /**
      * Handles manual setup for P2P
      * @param userMode
@@ -334,8 +303,6 @@ export class SetupManager extends AbstractModule {
             return await this.onBucketManualSetup(userMode, currentSetting, true);
         } else if (method === "p2p") {
             return await this.onP2PManualSetup(userMode, currentSetting, true);
-        } else if (method === "webdav") {
-            return await this.onWebDAVManualSetup(userMode, currentSetting, true);
         } else if (method === "cancelled") {
             this._log("Manual configuration cancelled.", LOG_LEVEL_NOTICE);
             if (userMode !== UserMode.Unknown) {

src/modules/features/SetupWizard/dialogs/SetupRemote.svelte

@@ -10,7 +10,6 @@
         TYPE_COUCHDB,
         TYPE_BUCKET,
         TYPE_P2P,
-        TYPE_WEBDAV,
         TYPE_CANCELLED,
         type SetupRemoteResultType,
     } from "./setupDialogTypes";
@@ -27,19 +26,12 @@
             return "Continue to S3/MinIO/R2 setup";
         } else if (userType === TYPE_P2P) {
             return "Continue to Peer-to-Peer only setup";
-        } else if (userType === TYPE_WEBDAV) {
-            return "Continue to WebDAV setup";
         } else {
             return "Please select an option to proceed";
         }
     });
     const canProceed = $derived.by(() => {
-        return (
-            userType === TYPE_COUCHDB ||
-            userType === TYPE_BUCKET ||
-            userType === TYPE_P2P ||
-            userType === TYPE_WEBDAV
-        );
+        return userType === TYPE_COUCHDB || userType === TYPE_BUCKET || userType === TYPE_P2P;
     });
 </script>
 
@@ -54,10 +46,6 @@
         <Option selectedValue={TYPE_BUCKET} title="S3/MinIO/R2 Object Storage" bind:value={userType}>
             Synchronisation utilising journal files. You must have set up an S3/MinIO/R2 compatible object storage.
         </Option>
-        <Option selectedValue={TYPE_WEBDAV} title="WebDAV (Experimental)" bind:value={userType}>
-            Experimental synchronisation utilising journal files stored in a WebDAV collection. This is a proof of
-            concept for pluggable Journal storage backends.
-        </Option>
         <Option selectedValue={TYPE_P2P} title="Peer-to-Peer only" bind:value={userType}>
             This feature enables direct synchronisation between devices. No server is required, but both devices must be
             online at the same time for synchronisation to occur, and some features may be limited. Internet connection

src/modules/features/SetupWizard/dialogs/SetupRemoteWebDAV.svelte

@@ -1,160 +0,0 @@
-<script lang="ts">
-    import DialogHeader from "@lib/UI/components/DialogHeader.svelte";
-    import Guidance from "@lib/UI/components/Guidance.svelte";
-    import Decision from "@lib/UI/components/Decision.svelte";
-    import UserDecisions from "@lib/UI/components/UserDecisions.svelte";
-    import InfoNote from "@lib/UI/components/InfoNote.svelte";
-    import InputRow from "@lib/UI/components/InputRow.svelte";
-    import {
-        DEFAULT_SETTINGS,
-        PREFERRED_JOURNAL_SYNC,
-        RemoteTypes,
-        type ObsidianLiveSyncSettings,
-        type WebDAVSyncSetting,
-    } from "@lib/common/types";
-    import { copyTo, pickWebDAVSyncSettings } from "@lib/common/utils";
-    import { getDialogContext, type GuestDialogProps } from "@lib/UI/svelteDialog";
-    import { onMount } from "svelte";
-    import { TYPE_CANCELLED, type SetupRemoteWebDAVResultType } from "./setupDialogTypes";
-
-    const default_setting = pickWebDAVSyncSettings(DEFAULT_SETTINGS);
-
-    let syncSetting = $state<WebDAVSyncSetting>({ ...default_setting });
-
-    type Props = GuestDialogProps<SetupRemoteWebDAVResultType, WebDAVSyncSetting>;
-
-    const { setResult, getInitialData }: Props = $props();
-
-    onMount(() => {
-        if (getInitialData) {
-            const initialData = getInitialData();
-            if (initialData) {
-                copyTo(initialData, syncSetting);
-            }
-        }
-    });
-
-    let error = $state("");
-    let processing = $state(false);
-    const context = getDialogContext();
-
-    function parseURI(): URL | false {
-        const match = syncSetting.webDAVactiveConnectionURI.trim().match(/^sls\+webdav:(.*)$/);
-        if (!match) {
-            return false;
-        }
-        try {
-            return new URL(`https:${match[1]}`);
-        } catch {
-            return false;
-        }
-    }
-
-    const parsedURI = $derived.by(() => parseURI());
-    const canProceed = $derived.by(() => parsedURI !== false);
-    const isInsecure = $derived.by(() => parsedURI !== false && parsedURI.searchParams.get("insecure") === "true");
-    const usesInternalAPI = $derived.by(
-        () => parsedURI !== false && parsedURI.searchParams.get("useProxy") === "true"
-    );
-
-    function generateSetting() {
-        const trialSettings: WebDAVSyncSetting = {
-            ...syncSetting,
-            webDAVactiveConnectionURI: syncSetting.webDAVactiveConnectionURI.trim(),
-        };
-        const trialRemoteSetting: ObsidianLiveSyncSettings = {
-            ...DEFAULT_SETTINGS,
-            ...PREFERRED_JOURNAL_SYNC,
-            remoteType: RemoteTypes.REMOTE_WEBDAV,
-            ...trialSettings,
-        };
-        return trialRemoteSetting;
-    }
-
-    async function checkConnection() {
-        try {
-            processing = true;
-            const trialRemoteSetting = generateSetting();
-            const replicator = await context.services.replicator.getNewReplicator(trialRemoteSetting);
-            if (!replicator) {
-                return "Failed to create replicator instance.";
-            }
-            try {
-                const result = await replicator.tryConnectRemote(trialRemoteSetting, false);
-                if (result) {
-                    return "";
-                }
-                return "Failed to connect to the server. Please check your settings.";
-            } catch (e) {
-                return `Failed to connect to the server: ${e}`;
-            }
-        } finally {
-            processing = false;
-        }
-    }
-
-    async function checkAndCommit() {
-        error = "";
-        try {
-            error = (await checkConnection()) || "";
-            if (!error) {
-                setResult(pickWebDAVSyncSettings(generateSetting()));
-                return;
-            }
-        } catch (e) {
-            error = `Error during connection test: ${e}`;
-        }
-    }
-
-    function commit() {
-        setResult(pickWebDAVSyncSettings(generateSetting()));
-    }
-
-    function cancel() {
-        setResult(TYPE_CANCELLED);
-    }
-</script>
-
-<DialogHeader title="WebDAV Configuration" />
-<Guidance>
-    Please enter the WebDAV connection URI. This experimental setup stores Journal synchronisation files in a WebDAV
-    collection.
-</Guidance>
-
-<InputRow label="Connection URI">
-    <input
-        type="text"
-        name="webdav-connection-uri"
-        placeholder="sls+webdav://user:password@example.com/dav?prefix=vault%2F"
-        autocorrect="off"
-        autocapitalize="off"
-        spellcheck="false"
-        required
-        bind:value={syncSetting.webDAVactiveConnectionURI}
-    />
-</InputRow>
-<InfoNote>
-    Use `sls+webdav://user:password@host/path`. Optional query parameters include `prefix`, `useProxy=true`, and
-    `insecure=true` for local HTTP testing.
-</InfoNote>
-<InfoNote warning visible={isInsecure}>Secure HTTPS connections are required on Obsidian Mobile.</InfoNote>
-<InfoNote visible={usesInternalAPI}>
-    This connection uses Obsidian's internal API. It can help when direct WebDAV requests are blocked by CORS.
-</InfoNote>
-<InfoNote error visible={syncSetting.webDAVactiveConnectionURI.trim() !== "" && !canProceed}>
-    The connection URI must start with `sls+webdav://`.
-</InfoNote>
-
-<InfoNote error visible={error !== ""}>
-    {error}
-</InfoNote>
-
-{#if processing}
-    Checking connection... Please wait.
-{:else}
-    <UserDecisions>
-        <Decision title="Test Settings and Continue" important disabled={!canProceed} commit={() => checkAndCommit()} />
-        <Decision title="Continue anyway" disabled={!canProceed} commit={() => commit()} />
-        <Decision title="Cancel" commit={() => cancel()} />
-    </UserDecisions>
-{/if}

src/modules/features/SetupWizard/dialogs/setupDialogTypes.ts

@@ -4,7 +4,6 @@ import type {
     EncryptionSettings,
     ObsidianLiveSyncSettings,
     P2PConnectionInfo,
-    WebDAVSyncSetting,
 } from "@lib/common/models/setting.type";
 
 export const TYPE_IDENTICAL = "identical";
@@ -41,7 +40,6 @@ export const TYPE_CLOSE = "close";
 export const TYPE_COUCHDB = "couchdb";
 export const TYPE_BUCKET = "bucket";
 export const TYPE_P2P = "p2p";
-export const TYPE_WEBDAV = "webdav";
 
 export type ResultTypeVault =
     | typeof TYPE_IDENTICAL
@@ -95,12 +93,7 @@ export type SelectMethodExistingResultType =
     | typeof TYPE_CONFIGURE_MANUALLY
     | typeof TYPE_CANCELLED;
 
-export type SetupRemoteResultType =
-    | typeof TYPE_COUCHDB
-    | typeof TYPE_BUCKET
-    | typeof TYPE_P2P
-    | typeof TYPE_WEBDAV
-    | typeof TYPE_CANCELLED;
+export type SetupRemoteResultType = typeof TYPE_COUCHDB | typeof TYPE_BUCKET | typeof TYPE_P2P | typeof TYPE_CANCELLED;
 
 export type UseSetupURIResultType = typeof TYPE_CANCELLED | ObsidianLiveSyncSettings;
 
@@ -112,6 +105,4 @@ export type SetupRemoteCouchDBResultType = typeof TYPE_CANCELLED | CouchDBConnec
 
 export type SetupRemoteP2PResultType = typeof TYPE_CANCELLED | P2PConnectionInfo;
 
-export type SetupRemoteWebDAVResultType = typeof TYPE_CANCELLED | WebDAVSyncSetting;
-
 export type ScanQRCodeResultType = typeof TYPE_CLOSE;

src/modules/services/ObsidianAPIService.ts

@@ -147,12 +147,14 @@ export class ObsidianAPIService extends InjectableAPIService<ObsidianServiceCont
                 : req instanceof Request && typeof req.method === "string"
                   ? req.method
                   : "GET";
-        if (opts?.body) {
-            body = typeof opts.body === "string" ? opts.body : await new Response(opts.body).arrayBuffer();
-        } else if (typeof req !== "string" && req.body) {
-            body = await new Response(req.body).arrayBuffer();
+        if (typeof req !== "string") {
+            if (opts?.body) {
+                body = typeof opts.body === "string" ? opts.body : await new Response(opts.body).arrayBuffer();
+            } else if (req.body) {
+                body = await new Response(req.body).arrayBuffer();
+            }
         } else {
-            body = undefined;
+            body = opts?.body as string;
         }
         const reqHeaders = new Headers(req instanceof Request ? req.headers : {});
 

src/modules/services/ObsidianAPIService.unit.spec.ts

@@ -1,63 +0,0 @@
-import { describe, expect, it, vi } from "vitest";
-
-const requestUrlMock = vi.hoisted(() => vi.fn());
-
-vi.mock("@/deps", () => {
-    return {
-        requestUrl: requestUrlMock,
-        Notice: vi.fn(),
-        Platform: {},
-    };
-});
-
-vi.mock("@/deps.ts", () => {
-    return {
-        requestUrl: requestUrlMock,
-        Notice: vi.fn(),
-        Platform: {},
-    };
-});
-
-vi.mock("./ObsidianConfirm", () => ({
-    ObsidianConfirm: class {},
-}));
-
-import { ObsidianAPIService } from "./ObsidianAPIService.ts";
-import type { ObsidianServiceContext } from "@lib/services/implements/obsidian/ObsidianServiceContext.ts";
-
-describe("ObsidianAPIService.nativeFetch", () => {
-    it("should pass binary string-request bodies to requestUrl as ArrayBuffer", async () => {
-        requestUrlMock.mockResolvedValueOnce({
-            arrayBuffer: new TextEncoder().encode("ok").buffer,
-            headers: {},
-            status: 207,
-        });
-        const service = new ObsidianAPIService({} as ObsidianServiceContext);
-        const body = new TextEncoder().encode("payload");
-
-        const response = await service.nativeFetch("https://webdav.example.com/file", {
-            method: "PUT",
-            body: body as unknown as BodyInit,
-            headers: {
-                Depth: "1",
-                Authorization: "Basic dXNlcjpwYXNz",
-            },
-        });
-
-        expect(response.status).toBe(207);
-        expect(requestUrlMock).toHaveBeenCalledWith(
-            expect.objectContaining({
-                url: "https://webdav.example.com/file",
-                method: "PUT",
-                body: expect.any(ArrayBuffer),
-                headers: expect.objectContaining({
-                    Depth: "1",
-                    Authorization: "Basic dXNlcjpwYXNz",
-                }),
-                throw: false,
-            })
-        );
-        const requestBody = requestUrlMock.mock.calls[0][0].body as ArrayBuffer;
-        expect(new TextDecoder().decode(requestBody)).toBe("payload");
-    });
-});

test/e2e-obsidian/README.md

@@ -2,6 +2,8 @@
 
 This directory contains the experimental real Obsidian end-to-end runner.
 
+The generic application discovery, isolated-vault, plug-in installation, process lifecycle, CLI, CDP, and readiness implementation comes from `@vrtmrz/obsidian-test-session`. The small modules under `runner/` preserve LiveSync's existing imports and supply its plug-in ID and artefact location. LiveSync-specific fixtures, services, settings, workflows, and assertions remain in this repository.
+
 The current smoke runner verifies only the launch path:
 
 1. create a temporary vault,
@@ -18,7 +20,7 @@ The runner does not require Self-hosted LiveSync to expose an E2E-only bridge. R
 
 Obsidian 1.12 stores the global community plug-in switch outside `.obsidian/community-plugins.json`. The smoke runner enables it through `app.plugins.setEnable(true)` after the vault window is available.
 
-Future workflows should use `startObsidianLiveSyncSession()` from `runner/session.ts` rather than repeating the launch and plug-in readiness sequence.
+Future workflows should use `startObsidianLiveSyncSession()` from `runner/session.ts` rather than repeating the launch and plug-in readiness sequence. Add generic Obsidian bootstrap improvements to Fancy Kit; keep LiveSync behaviour and scenario helpers here.
 
 Each test vault uses an isolated Obsidian profile. The runner creates temporary directories for `HOME`, `XDG_CONFIG_HOME`, `XDG_CACHE_HOME`, `XDG_DATA_HOME`, and Electron `--user-data-dir`, writes the vault registry into those directories, pre-seeds the temporary Chromium local storage so community plug-ins are trusted for that generated vault ID, and passes the same environment to `obsidian-cli`. This is intended to keep real Obsidian E2E runs separate from a developer's daily Obsidian profile and vault registry.
 

test/e2e-obsidian/runner/cli.ts

@@ -1,103 +1,6 @@
-import { spawn } from "node:child_process";
-
-export type ObsidianCliResult = {
-    code: number | null;
-    signal: NodeJS.Signals | null;
-    stdout: string;
-    stderr: string;
-};
-
-function parseEvalJson(stdout: string): unknown {
-    const marker = "=> ";
-    const markerIndex = stdout.indexOf(marker);
-    const text = markerIndex >= 0 ? stdout.slice(markerIndex + marker.length) : stdout;
-    return JSON.parse(text.trim());
-}
-
-export async function runObsidianCli(
-    cliBinary: string,
-    args: string[],
-    env: NodeJS.ProcessEnv = process.env,
-    timeoutMs = Number(process.env.E2E_OBSIDIAN_CLI_TIMEOUT_MS ?? 10000)
-): Promise<ObsidianCliResult> {
-    return await new Promise((resolve, reject) => {
-        const child = spawn(cliBinary, args, {
-            stdio: ["ignore", "pipe", "pipe"],
-            env,
-        });
-        let stdout = "";
-        let stderr = "";
-        const timeout = setTimeout(() => {
-            child.kill("SIGKILL");
-            reject(new Error(`Obsidian CLI timed out: ${cliBinary} ${args.join(" ")}`));
-        }, timeoutMs);
-
-        child.stdout?.on("data", (chunk: Buffer) => {
-            stdout += chunk.toString();
-        });
-        child.stderr?.on("data", (chunk: Buffer) => {
-            stderr += chunk.toString();
-        });
-        child.on("error", (error) => {
-            clearTimeout(timeout);
-            reject(error);
-        });
-        child.on("exit", (code, signal) => {
-            clearTimeout(timeout);
-            resolve({ code, signal, stdout, stderr });
-        });
-    });
-}
-
-export async function openVaultWithObsidianCli(
-    cliBinary: string,
-    vaultPath: string,
-    env: NodeJS.ProcessEnv = process.env
-): Promise<void> {
-    const result = await runObsidianCli(cliBinary, [`obsidian://open?path=${encodeURIComponent(vaultPath)}`], env);
-    if (result.code !== 0) {
-        throw new Error(
-            [
-                `Failed to open Obsidian vault through CLI. code=${result.code}, signal=${result.signal}`,
-                result.stdout ? `stdout:\n${result.stdout}` : undefined,
-                result.stderr ? `stderr:\n${result.stderr}` : undefined,
-            ]
-                .filter(Boolean)
-                .join("\n")
-        );
-    }
-}
-
-export async function evalObsidianJson<T>(
-    cliBinary: string,
-    code: string,
-    env: NodeJS.ProcessEnv = process.env,
-    timeoutMs?: number
-): Promise<T> {
-    const result = await runObsidianCli(cliBinary, ["eval", `code=${code}`], env, timeoutMs);
-    if (result.code !== 0) {
-        throw new Error(
-            [
-                `Failed to evaluate Obsidian JavaScript through CLI. code=${result.code}, signal=${result.signal}`,
-                result.stdout ? `stdout:\n${result.stdout}` : undefined,
-                result.stderr ? `stderr:\n${result.stderr}` : undefined,
-            ]
-                .filter(Boolean)
-                .join("\n")
-        );
-    }
-    try {
-        return parseEvalJson(result.stdout) as T;
-    } catch (error) {
-        throw new Error(
-            [
-                `Failed to parse Obsidian CLI eval JSON. code=${result.code}, signal=${result.signal}`,
-                error instanceof Error ? `parse error: ${error.message}` : undefined,
-                result.stdout ? `stdout:\n${result.stdout}` : undefined,
-                result.stderr ? `stderr:\n${result.stderr}` : undefined,
-            ]
-                .filter(Boolean)
-                .join("\n")
-        );
-    }
-}
+export {
+    evalObsidianJson,
+    openVaultWithObsidianCli,
+    runObsidianCli,
+    type ObsidianCliResult,
+} from "@vrtmrz/obsidian-test-session";

test/e2e-obsidian/runner/environment.ts

@@ -1,149 +1,7 @@
-import { accessSync, constants, existsSync } from "node:fs";
-import { resolve } from "node:path";
-import { platform } from "node:process";
-
-export type ObsidianDiscoveryResult = {
-    binary?: string;
-    source?: string;
-    checked: string[];
-};
-
-const defaultCandidatesByPlatform: Record<NodeJS.Platform, string[]> = {
-    aix: [],
-    android: [],
-    darwin: [
-        "/Applications/Obsidian.app/Contents/MacOS/Obsidian",
-        "/Applications/Obsidian.app/Contents/MacOS/obsidian",
-    ],
-    freebsd: [],
-    haiku: [],
-    linux: [
-        "_testdata/obsidian/squashfs-root/obsidian",
-        "_testdata/obsidian/squashfs-root/AppRun",
-        "_testdata/obsidian/Obsidian-1.12.7-arm64.AppImage",
-        "_testdata/obsidian/Obsidian-1.12.7-x86_64.AppImage",
-        "/usr/bin/obsidian",
-        "/usr/local/bin/obsidian",
-        "/snap/bin/obsidian",
-        "/opt/Obsidian/obsidian",
-        "/opt/obsidian/obsidian",
-        "/app/bin/obsidian",
-    ],
-    openbsd: [],
-    sunos: [],
-    win32: ["C:\\Program Files\\Obsidian\\Obsidian.exe", "C:\\Program Files (x86)\\Obsidian\\Obsidian.exe"],
-    cygwin: [],
-    netbsd: [],
-};
-
-const defaultCliCandidatesByPlatform: Record<NodeJS.Platform, string[]> = {
-    aix: [],
-    android: [],
-    darwin: [
-        "/Applications/Obsidian.app/Contents/MacOS/obsidian-cli",
-        "/Applications/Obsidian.app/Contents/Resources/obsidian-cli",
-    ],
-    freebsd: [],
-    haiku: [],
-    linux: [
-        "_testdata/obsidian/squashfs-root/obsidian-cli",
-        "/usr/bin/obsidian-cli",
-        "/usr/local/bin/obsidian-cli",
-        "/snap/bin/obsidian-cli",
-        "/opt/Obsidian/obsidian-cli",
-        "/opt/obsidian/obsidian-cli",
-    ],
-    openbsd: [],
-    sunos: [],
-    win32: ["C:\\Program Files\\Obsidian\\obsidian-cli.exe", "C:\\Program Files (x86)\\Obsidian\\obsidian-cli.exe"],
-    cygwin: [],
-    netbsd: [],
-};
-
-function isUsableFile(path: string): boolean {
-    const resolvedPath = resolve(path);
-    if (!existsSync(resolvedPath)) {
-        return false;
-    }
-    if (platform === "win32") {
-        return true;
-    }
-    try {
-        accessSync(resolvedPath, constants.X_OK);
-        return true;
-    } catch {
-        return false;
-    }
-}
-
-export function discoverObsidianBinary(env: NodeJS.ProcessEnv = process.env): ObsidianDiscoveryResult {
-    const checked: string[] = [];
-    const envBinary = env.OBSIDIAN_BINARY?.trim();
-    if (envBinary) {
-        checked.push(envBinary);
-        if (isUsableFile(envBinary)) {
-            return {
-                binary: resolve(envBinary),
-                source: "OBSIDIAN_BINARY",
-                checked,
-            };
-        }
-    }
-
-    const candidates = defaultCandidatesByPlatform[platform] ?? [];
-    for (const candidate of candidates) {
-        checked.push(candidate);
-        if (isUsableFile(candidate)) {
-            return {
-                binary: resolve(candidate),
-                source: "default-path",
-                checked,
-            };
-        }
-    }
-
-    return { checked };
-}
-
-export function requireObsidianBinary(env: NodeJS.ProcessEnv = process.env): string {
-    const result = discoverObsidianBinary(env);
-    if (!result.binary) {
-        throw new Error(
-            [
-                "Could not find an Obsidian executable.",
-                "Set OBSIDIAN_BINARY to the installed Obsidian executable path.",
-                `Checked paths: ${result.checked.length > 0 ? result.checked.join(", ") : "(none)"}`,
-            ].join("\n")
-        );
-    }
-    return result.binary;
-}
-
-export function discoverObsidianCli(env: NodeJS.ProcessEnv = process.env): ObsidianDiscoveryResult {
-    const checked: string[] = [];
-    const envBinary = env.OBSIDIAN_CLI?.trim();
-    if (envBinary) {
-        checked.push(envBinary);
-        if (isUsableFile(envBinary)) {
-            return {
-                binary: resolve(envBinary),
-                source: "OBSIDIAN_CLI",
-                checked,
-            };
-        }
-    }
-
-    const candidates = defaultCliCandidatesByPlatform[platform] ?? [];
-    for (const candidate of candidates) {
-        checked.push(candidate);
-        if (isUsableFile(candidate)) {
-            return {
-                binary: resolve(candidate),
-                source: "default-path",
-                checked,
-            };
-        }
-    }
-
-    return { checked };
-}
+export {
+    discoverObsidianBinary,
+    discoverObsidianCli,
+    requireObsidianBinary,
+    requireObsidianCli,
+    type ObsidianDiscoveryResult,
+} from "@vrtmrz/obsidian-test-session";

test/e2e-obsidian/runner/launch.ts

@@ -1,196 +1,26 @@
-import { execFile, spawn, type ChildProcess } from "node:child_process";
-import { once } from "node:events";
-import { existsSync } from "node:fs";
-import { dirname } from "node:path";
-import { platform } from "node:process";
-import { promisify } from "node:util";
+import {
+    cleanupStaleObsidianE2EProcesses as cleanupStaleProcesses,
+    launchObsidian as launchObsidianSession,
+    type LaunchObsidianOptions,
+    type ObsidianProcess,
+    type ObsidianProcessOutput,
+} from "@vrtmrz/obsidian-test-session";
 
-export type ObsidianProcess = {
-    process: ChildProcess;
-    output: () => { stdout: string; stderr: string };
-    stop: () => Promise<void>;
-};
+export type { LaunchObsidianOptions, ObsidianProcess, ObsidianProcessOutput };
 
-export type LaunchObsidianOptions = {
-    binary: string;
-    vaultPath: string;
-    homePath?: string;
-    xdgConfigPath?: string;
-    xdgCachePath?: string;
-    xdgDataPath?: string;
-    userDataPath?: string;
-    startupGraceMs?: number;
-};
-
-const execFileAsync = promisify(execFile);
-
-function splitArgs(args: string): string[] {
-    return args.split(" ").filter((arg) => arg.length > 0);
-}
-
-function launchArgs(options: LaunchObsidianOptions): string[] {
-    const explicitArgs = process.env.E2E_OBSIDIAN_ARGS;
-    if (explicitArgs) {
-        return splitArgs(explicitArgs);
-    }
-    return [
-        "--no-sandbox",
-        "--disable-gpu",
-        "--disable-software-rasterizer",
-        ...(process.env.E2E_OBSIDIAN_USE_USER_DATA_DIR !== "false" && options.userDataPath
-            ? [`--user-data-dir=${options.userDataPath}`]
-            : []),
-        ...(process.env.E2E_OBSIDIAN_REMOTE_DEBUGGING_PORT
-            ? [`--remote-debugging-port=${process.env.E2E_OBSIDIAN_REMOTE_DEBUGGING_PORT}`]
-            : []),
-        `obsidian://open?path=${encodeURIComponent(options.vaultPath)}`,
-    ];
-}
-
-function shouldUseXvfb(): boolean {
-    if (process.env.E2E_OBSIDIAN_USE_XVFB === "false") {
-        return false;
-    }
-    if (process.env.DISPLAY || process.env.WAYLAND_DISPLAY) {
-        return false;
-    }
-    return platform === "linux" && existsSync("/usr/bin/xvfb-run");
-}
-
-async function listChildPids(pid: number): Promise<number[]> {
-    if (platform === "win32") {
-        return [];
-    }
-    const { stdout } = await execFileAsync("ps", ["-o", "pid=", "--ppid", String(pid)]).catch(() => ({
-        stdout: "",
-    }));
-    const directChildren = stdout
-        .split("\n")
-        .map((line) => Number(line.trim()))
-        .filter((childPid) => Number.isInteger(childPid) && childPid > 0);
-    const descendants = await Promise.all(directChildren.map((childPid) => listChildPids(childPid)));
-    return [...directChildren, ...descendants.flat()];
-}
-
-async function killPids(pids: number[], signal: NodeJS.Signals): Promise<void> {
-    for (const pid of pids) {
-        if (pid === process.pid) {
-            continue;
-        }
-        try {
-            process.kill(pid, signal);
-        } catch {
-            // The process may have exited between discovery and signalling.
-        }
-    }
-}
-
-async function waitForExit(exitPromise: Promise<unknown>, timeoutMs: number): Promise<"exited" | "timeout"> {
-    const stopTimer = new Promise<"timeout">((resolve) => {
-        setTimeout(() => resolve("timeout"), timeoutMs);
-    });
-    const stopResult = await Promise.race([exitPromise.then(() => "exited" as const), stopTimer]);
-    return stopResult;
-}
+const STALE_PROCESS_PATTERN = "obsidian-livesync-e2e-state";
 
 export async function cleanupStaleObsidianE2EProcesses(): Promise<void> {
-    if (process.env.E2E_OBSIDIAN_CLEANUP_STALE_PROCESSES === "false" || platform === "win32") {
-        return;
-    }
-    const { stdout } = await execFileAsync("pgrep", ["-f", "obsidian-livesync-e2e-state"]).catch(() => ({
-        stdout: "",
-    }));
-    const pids = stdout
-        .split("\n")
-        .map((line) => Number(line.trim()))
-        .filter((pid) => Number.isInteger(pid) && pid > 0 && pid !== process.pid);
-    if (pids.length === 0) {
-        return;
-    }
-    await killPids(pids, "SIGTERM");
-    await new Promise((resolve) => setTimeout(resolve, 1000));
-    await killPids(pids, "SIGKILL");
+    await cleanupStaleProcesses(STALE_PROCESS_PATTERN);
 }
 
 export async function launchObsidian(options: LaunchObsidianOptions): Promise<ObsidianProcess> {
-    await cleanupStaleObsidianE2EProcesses();
-    const startupGraceMs = options.startupGraceMs ?? 1000;
-    const args = launchArgs(options);
-    const useXvfb = shouldUseXvfb();
-    const command = useXvfb ? "/usr/bin/xvfb-run" : options.binary;
-    const commandArgs = useXvfb ? ["-a", options.binary, ...args] : args;
-    const child = spawn(command, commandArgs, {
-        cwd: dirname(options.binary),
-        detached: true,
-        stdio: ["ignore", "pipe", "pipe"],
-        env: {
-            ...process.env,
-            ...(options.homePath ? { HOME: options.homePath } : {}),
-            ...(options.xdgConfigPath ? { XDG_CONFIG_HOME: options.xdgConfigPath } : {}),
-            ...(options.xdgCachePath ? { XDG_CACHE_HOME: options.xdgCachePath } : {}),
-            ...(options.xdgDataPath ? { XDG_DATA_HOME: options.xdgDataPath } : {}),
-            OBSIDIAN_DISABLE_GPU: process.env.OBSIDIAN_DISABLE_GPU ?? "1",
-        },
+    const configuredPort =
+        options.env?.E2E_OBSIDIAN_REMOTE_DEBUGGING_PORT ?? process.env.E2E_OBSIDIAN_REMOTE_DEBUGGING_PORT;
+    return await launchObsidianSession({
+        ...options,
+        remoteDebuggingPort:
+            options.remoteDebuggingPort ?? (configuredPort === undefined ? undefined : Number(configuredPort)),
+        staleProcessPattern: options.staleProcessPattern ?? STALE_PROCESS_PATTERN,
     });
-
-    let stderr = "";
-    let stdout = "";
-    child.stderr?.on("data", (chunk: Buffer) => {
-        stderr += chunk.toString();
-    });
-    child.stdout?.on("data", (chunk: Buffer) => {
-        stdout += chunk.toString();
-    });
-
-    const exitPromise = once(child, "exit").then(([code, signal]) => ({ code, signal }));
-    const timer = new Promise<"timeout">((resolve) => {
-        setTimeout(() => resolve("timeout"), startupGraceMs);
-    });
-    const firstResult = await Promise.race([exitPromise, timer]);
-    if (firstResult !== "timeout") {
-        throw new Error(
-            [
-                `Obsidian exited before the smoke timeout. code=${firstResult.code}, signal=${firstResult.signal}`,
-                stdout ? `stdout:\n${stdout}` : undefined,
-                stderr ? `stderr:\n${stderr}` : undefined,
-            ]
-                .filter(Boolean)
-                .join("\n")
-        );
-    }
-
-    return {
-        process: child,
-        output: () => ({ stdout, stderr }),
-        stop: async () => {
-            if (child.exitCode !== null || child.signalCode !== null) {
-                return;
-            }
-            const descendantPids = child.pid ? await listChildPids(child.pid) : [];
-            if (child.pid) {
-                try {
-                    process.kill(-child.pid, "SIGTERM");
-                } catch {
-                    child.kill("SIGTERM");
-                }
-            } else {
-                child.kill("SIGTERM");
-            }
-            await killPids(descendantPids.reverse(), "SIGTERM");
-            const stopResult = await waitForExit(exitPromise, 5000);
-            if (stopResult === "timeout") {
-                if (child.pid) {
-                    try {
-                        process.kill(-child.pid, "SIGKILL");
-                    } catch {
-                        child.kill("SIGKILL");
-                    }
-                } else {
-                    child.kill("SIGKILL");
-                }
-                await killPids(descendantPids, "SIGKILL");
-                await exitPromise;
-            }
-        },
-    };
 }

test/e2e-obsidian/runner/pluginInstaller.ts

@@ -1,39 +1,13 @@
-import { copyFile, mkdir, writeFile } from "node:fs/promises";
-import { existsSync } from "node:fs";
-import { join, resolve } from "node:path";
+import {
+    installBuiltPlugin as installGenericBuiltPlugin,
+    type PluginInstallResult,
+} from "@vrtmrz/obsidian-test-session";
 
-export type PluginInstallResult = {
-    pluginDir: string;
-    copied: string[];
-};
-
-const pluginId = "obsidian-livesync";
+export type { PluginInstallResult };
 
 export async function installBuiltPlugin(vaultPath: string, rootDir = process.cwd()): Promise<PluginInstallResult> {
-    const pluginDir = join(vaultPath, ".obsidian", "plugins", pluginId);
-    const copied: string[] = [];
-    await mkdir(pluginDir, { recursive: true });
-
-    const requiredArtifacts = ["main.js", "manifest.json"];
-    for (const artifact of requiredArtifacts) {
-        const source = resolve(rootDir, artifact);
-        if (!existsSync(source)) {
-            throw new Error(`Required plug-in artifact is missing: ${source}`);
-        }
-        await copyFile(source, join(pluginDir, artifact));
-        copied.push(artifact);
-    }
-
-    const optionalArtifacts = ["styles.css"];
-    for (const artifact of optionalArtifacts) {
-        const source = resolve(rootDir, artifact);
-        if (!existsSync(source)) {
-            continue;
-        }
-        await copyFile(source, join(pluginDir, artifact));
-        copied.push(artifact);
-    }
-
-    await writeFile(join(vaultPath, ".obsidian", "community-plugins.json"), JSON.stringify([pluginId], null, 4));
-    return { pluginDir, copied };
+    return await installGenericBuiltPlugin(vaultPath, {
+        pluginId: "obsidian-livesync",
+        artifactRoot: rootDir,
+    });
 }

test/e2e-obsidian/runner/readiness.ts

@@ -1,41 +1 @@
-import { evalObsidianJson } from "./cli.ts";
-
-export type PluginReadiness = {
-    status: "ready";
-    pluginId: string;
-    pluginVersion: string;
-    vaultName: string;
-};
-
-export async function waitForPluginReady(
-    cliBinary: string,
-    env: NodeJS.ProcessEnv,
-    timeoutMs = Number(process.env.E2E_OBSIDIAN_READY_TIMEOUT_MS ?? 20000)
-): Promise<PluginReadiness> {
-    const deadline = Date.now() + timeoutMs;
-    let lastOutput = "";
-    while (Date.now() < deadline) {
-        try {
-            const readiness = await evalObsidianJson<PluginReadiness>(
-                cliBinary,
-                [
-                    "(async()=>JSON.stringify({",
-                    "status:!!app.plugins.plugins['obsidian-livesync']?'ready':'pending',",
-                    "pluginId:'obsidian-livesync',",
-                    "pluginVersion:app.plugins.manifests['obsidian-livesync']?.version,",
-                    "vaultName:app.vault.getName()",
-                    "}))()",
-                ].join(""),
-                env
-            );
-            if (readiness.status === "ready") {
-                return readiness;
-            }
-        } catch (error) {
-            lastOutput = error instanceof Error ? error.message : String(error);
-            // Keep polling until Obsidian exposes the vault-side CLI and plug-in state.
-        }
-        await new Promise((resolve) => setTimeout(resolve, 500));
-    }
-    throw new Error(`Timed out waiting for Self-hosted LiveSync readiness through Obsidian CLI.\n${lastOutput}`);
-}
+export { waitForPluginReady, type PluginReadiness } from "@vrtmrz/obsidian-test-session";

test/e2e-obsidian/runner/session.ts

@@ -1,16 +1,7 @@
-import { evalObsidianJson, openVaultWithObsidianCli, runObsidianCli } from "./cli.ts";
-import { launchObsidian, type ObsidianProcess } from "./launch.ts";
-import { installBuiltPlugin, type PluginInstallResult } from "./pluginInstaller.ts";
-import { waitForPluginReady, type PluginReadiness } from "./readiness.ts";
+import { startObsidianPluginSession, type ObsidianPluginSession } from "@vrtmrz/obsidian-test-session";
 import type { TemporaryVault } from "./vault.ts";
-import { obsidianRemoteDebuggingPort, preseedTrustedVaultState, trustVaultIfPrompted } from "./ui.ts";
 
-export type ObsidianLiveSyncSession = {
-    app: ObsidianProcess;
-    cliEnv: NodeJS.ProcessEnv;
-    install: PluginInstallResult;
-    readiness: PluginReadiness;
-};
+export type ObsidianLiveSyncSession = ObsidianPluginSession;
 
 export type StartObsidianLiveSyncSessionOptions = {
     binary: string;
@@ -19,101 +10,15 @@ export type StartObsidianLiveSyncSessionOptions = {
     startupGraceMs?: number;
 };
 
-async function waitForPluginCatalogue(cliBinary: string, env: NodeJS.ProcessEnv): Promise<void> {
-    const deadline = Date.now() + Number(process.env.E2E_OBSIDIAN_CLI_READY_TIMEOUT_MS ?? 60000);
-    let lastOutput = "";
-    while (Date.now() < deadline) {
-        try {
-            const result = await evalObsidianJson<{ hasLiveSync: boolean }>(
-                cliBinary,
-                ["JSON.stringify({", "hasLiveSync:!!app.plugins?.manifests?.['obsidian-livesync']", "})"].join(""),
-                env
-            );
-            lastOutput = JSON.stringify(result);
-            if (result.hasLiveSync) {
-                return;
-            }
-        } catch (error) {
-            lastOutput = error instanceof Error ? error.message : String(error);
-        }
-        await new Promise((resolve) => setTimeout(resolve, 500));
-    }
-    throw new Error(`Timed out waiting for Obsidian plug-in catalogue through CLI.\n${lastOutput}`);
-}
-
-async function enableCommunityPlugins(cliBinary: string, env: NodeJS.ProcessEnv): Promise<void> {
-    const result = await runObsidianCli(cliBinary, ["eval", "code=(async()=>app.plugins.setEnable(true))()"], env);
-    if (result.code !== 0 || result.stdout.includes("Error:")) {
-        throw new Error(
-            [
-                `Failed to enable Obsidian community plug-ins through CLI. code=${result.code}, signal=${result.signal}`,
-                result.stdout ? `stdout:\n${result.stdout}` : undefined,
-                result.stderr ? `stderr:\n${result.stderr}` : undefined,
-            ]
-                .filter(Boolean)
-                .join("\n")
-        );
-    }
-}
-
-async function reloadLiveSyncPlugin(cliBinary: string, env: NodeJS.ProcessEnv): Promise<void> {
-    const reload = await runObsidianCli(cliBinary, ["plugin:reload", "id=obsidian-livesync"], env);
-    if (reload.code !== 0 || !reload.stdout.includes("Reloaded: obsidian-livesync")) {
-        throw new Error(
-            [
-                `Failed to reload Self-hosted LiveSync through Obsidian CLI. code=${reload.code}, signal=${reload.signal}`,
-                reload.stdout ? `stdout:\n${reload.stdout}` : undefined,
-                reload.stderr ? `stderr:\n${reload.stderr}` : undefined,
-            ]
-                .filter(Boolean)
-                .join("\n")
-        );
-    }
-}
-
 export async function startObsidianLiveSyncSession(
     options: StartObsidianLiveSyncSessionOptions
 ): Promise<ObsidianLiveSyncSession> {
-    const install = await installBuiltPlugin(options.vault.path);
-    const remoteDebuggingPort = obsidianRemoteDebuggingPort();
-    const app = await launchObsidian({
+    return await startObsidianPluginSession({
         binary: options.binary,
-        vaultPath: options.vault.path,
-        homePath: options.vault.homePath,
-        xdgConfigPath: options.vault.xdgConfigPath,
-        xdgCachePath: options.vault.xdgCachePath,
-        xdgDataPath: options.vault.xdgDataPath,
-        userDataPath: options.vault.userDataPath,
+        cliBinary: options.cliBinary,
+        vault: options.vault,
+        pluginId: "obsidian-livesync",
+        artifactRoot: process.cwd(),
         startupGraceMs: options.startupGraceMs,
     });
-    const cliEnv = {
-        ...process.env,
-        HOME: options.vault.homePath,
-        XDG_CONFIG_HOME: options.vault.xdgConfigPath,
-        XDG_CACHE_HOME: options.vault.xdgCachePath,
-        XDG_DATA_HOME: options.vault.xdgDataPath,
-    };
-
-    try {
-        await preseedTrustedVaultState(remoteDebuggingPort, options.vault.id);
-        await openVaultWithObsidianCli(options.cliBinary, options.vault.path, cliEnv);
-        await trustVaultIfPrompted(remoteDebuggingPort);
-        await waitForPluginCatalogue(options.cliBinary, cliEnv);
-        await enableCommunityPlugins(options.cliBinary, cliEnv);
-        await reloadLiveSyncPlugin(options.cliBinary, cliEnv);
-        const readiness = await waitForPluginReady(options.cliBinary, cliEnv);
-        return { app, cliEnv, install, readiness };
-    } catch (error) {
-        const output = app.output();
-        await app.stop();
-        throw new Error(
-            [
-                error instanceof Error ? error.message : String(error),
-                output.stdout ? `Obsidian stdout:\n${output.stdout}` : undefined,
-                output.stderr ? `Obsidian stderr:\n${output.stderr}` : undefined,
-            ]
-                .filter(Boolean)
-                .join("\n")
-        );
-    }
 }

test/e2e-obsidian/runner/ui.ts

@@ -1,74 +1,11 @@
-import { chromium, type Page } from "playwright";
+import { withObsidianPage } from "@vrtmrz/obsidian-test-session";
 
-export function obsidianRemoteDebuggingPort(): number {
-    const port = Number(process.env.E2E_OBSIDIAN_REMOTE_DEBUGGING_PORT ?? 9222);
-    process.env.E2E_OBSIDIAN_REMOTE_DEBUGGING_PORT = String(port);
-    return port;
-}
-
-async function waitForCdp(port: number): Promise<void> {
-    const deadline = Date.now() + Number(process.env.E2E_OBSIDIAN_CDP_TIMEOUT_MS ?? 30000);
-    while (Date.now() < deadline) {
-        try {
-            const response = await fetch(`http://127.0.0.1:${port}/json/version`);
-            if (response.ok) {
-                return;
-            }
-        } catch {
-            // Keep polling until Obsidian exposes the debugging endpoint.
-        }
-        await new Promise((resolve) => setTimeout(resolve, 500));
-    }
-    throw new Error(`Timed out waiting for Obsidian DevTools endpoint on port ${port}`);
-}
-
-export async function withObsidianPage<T>(port: number, operation: (page: Page) => Promise<T>): Promise<T> {
-    await waitForCdp(port);
-    const browser = await chromium.connectOverCDP(`http://127.0.0.1:${port}`);
-    try {
-        const context = browser.contexts()[0];
-        const page = context.pages()[0] ?? (await context.waitForEvent("page", { timeout: 10000 }));
-        return await operation(page);
-    } finally {
-        await browser.close();
-    }
-}
-
-export async function preseedTrustedVaultState(port: number, vaultId: string): Promise<void> {
-    await withObsidianPage(port, async (page) => {
-        await page.evaluate((id) => {
-            localStorage.setItem(`enable-plugin-${id}`, "true");
-        }, vaultId);
-        await page.reload({ waitUntil: "domcontentloaded", timeout: 10000 }).catch(() => undefined);
-        await page.waitForTimeout(1000);
-    });
-}
-
-export async function trustVaultIfPrompted(port: number): Promise<void> {
-    await withObsidianPage(port, async (page) => {
-        const deadline = Date.now() + Number(process.env.E2E_OBSIDIAN_TRUST_PROMPT_TIMEOUT_MS ?? 30000);
-        while (Date.now() < deadline) {
-            const yesButton = page.getByRole("button", { name: "Yes" });
-            if (await yesButton.isVisible({ timeout: 1000 }).catch(() => false)) {
-                await yesButton.click();
-                await page.waitForTimeout(500);
-                continue;
-            }
-
-            const trustButton = page.getByText("Trust author and enable plugins");
-            if (await trustButton.isVisible({ timeout: 1000 }).catch(() => false)) {
-                await trustButton.click();
-                await page.waitForTimeout(500);
-                continue;
-            }
-
-            const workspace = page.locator(".workspace");
-            if (await workspace.isVisible({ timeout: 1000 }).catch(() => false)) {
-                return;
-            }
-        }
-    });
-}
+export {
+    obsidianRemoteDebuggingPort,
+    preseedTrustedVaultState,
+    trustVaultIfPrompted,
+    withObsidianPage,
+} from "@vrtmrz/obsidian-test-session";
 
 export async function clickJsonResolveOption(port: number, mode: "AB" | "BA"): Promise<void> {
     await withObsidianPage(port, async (page) => {

test/e2e-obsidian/runner/vault.ts

@@ -1,94 +1,14 @@
-import { mkdtemp, mkdir, rm, writeFile } from "node:fs/promises";
-import { join } from "node:path";
-import { tmpdir } from "node:os";
+import {
+    createTemporaryVault as createGenericTemporaryVault,
+    type TemporaryVault,
+} from "@vrtmrz/obsidian-test-session";
 
-export type TemporaryVault = {
-    path: string;
-    name: string;
-    id: string;
-    homePath: string;
-    xdgConfigPath: string;
-    xdgCachePath: string;
-    xdgDataPath: string;
-    userDataPath: string;
-    dispose: () => Promise<void>;
-};
+export type { TemporaryVault };
 
 export async function createTemporaryVault(prefix = "obsidian-livesync-e2e-"): Promise<TemporaryVault> {
-    const vaultPath = await mkdtemp(join(tmpdir(), prefix));
-    const statePath = await mkdtemp(join(tmpdir(), `${prefix}state-`));
-    const name = vaultPath.split(/[\\/]/).pop() ?? "obsidian-livesync-e2e";
-    await mkdir(join(vaultPath, ".obsidian"), { recursive: true });
-    const homePath = join(statePath, "home");
-    const xdgConfigPath = join(statePath, "xdg-config");
-    const xdgCachePath = join(statePath, "xdg-cache");
-    const xdgDataPath = join(statePath, "xdg-data");
-    const userDataPath = join(statePath, "user-data");
-    const id = `livesync-e2e-${Date.now()}`;
-    await mkdir(homePath, { recursive: true });
-    await mkdir(xdgConfigPath, { recursive: true });
-    await mkdir(xdgCachePath, { recursive: true });
-    await mkdir(xdgDataPath, { recursive: true });
-    await mkdir(userDataPath, { recursive: true });
-    await writeFile(
-        join(vaultPath, ".obsidian", "app.json"),
-        JSON.stringify({ legacyEditor: false, safeMode: false }, null, 4)
-    );
-    await writeFile(
-        join(vaultPath, ".obsidian", "community-plugins.json"),
-        JSON.stringify(["obsidian-livesync"], null, 4)
-    );
-    await writeObsidianVaultRegistry(id, vaultPath, name, homePath, xdgConfigPath, userDataPath);
-
-    return {
-        path: vaultPath,
-        name,
-        id,
-        homePath,
-        xdgConfigPath,
-        xdgCachePath,
-        xdgDataPath,
-        userDataPath,
-        dispose: async () => {
-            if (process.env.E2E_OBSIDIAN_KEEP_VAULT === "true") {
-                console.log(`Keeping temporary vault: ${vaultPath}`);
-                console.log(`Keeping temporary Obsidian state: ${statePath}`);
-                return;
-            }
-            await Promise.all([
-                rm(vaultPath, { recursive: true, force: true, maxRetries: 5, retryDelay: 200 }),
-                rm(statePath, { recursive: true, force: true, maxRetries: 5, retryDelay: 200 }),
-            ]);
-        },
-    };
-}
-
-async function writeObsidianVaultRegistry(
-    vaultId: string,
-    vaultPath: string,
-    vaultName: string,
-    homePath: string,
-    xdgConfigPath: string,
-    userDataPath: string
-): Promise<void> {
-    const vaultRecord = {
-        path: vaultPath,
-        ts: Date.now(),
-        open: true,
-        name: vaultName,
-    };
-    const registry = {
-        cli: true,
-        vaults: {
-            [vaultId]: vaultRecord,
-        },
-    };
-    const registryText = JSON.stringify(registry, null, 4);
-    for (const configRoot of [join(homePath, ".config"), xdgConfigPath]) {
-        const obsidianConfigDir = join(configRoot, "obsidian");
-        await mkdir(obsidianConfigDir, { recursive: true });
-        await writeFile(join(obsidianConfigDir, "obsidian.json"), registryText);
-    }
-    await writeFile(join(userDataPath, "obsidian.json"), registryText);
-    await writeFile(join(userDataPath, `${vaultId}.json`), JSON.stringify(vaultRecord, null, 4));
+    return await createGenericTemporaryVault({
+        prefix,
+        pluginIds: ["obsidian-livesync"],
+        idPrefix: "livesync-e2e",
+    });
 }

test/shell/webdav-init.sh

@@ -1,4 +0,0 @@
-#!/bin/bash
-set -e
-
-docker inspect webdav-test >/dev/null

test/shell/webdav-start.sh

@@ -1,15 +0,0 @@
-#!/bin/bash
-set -e
-
-webdavUsername=${webdavUsername:-webdav}
-webdavPassword=${webdavPassword:-webdav}
-webdavPort=${webdavPort:-8088}
-
-docker run -d \
-  --name webdav-test \
-  -p "$webdavPort:8080" \
-  rclone/rclone serve webdav /data \
-  --addr :8080 \
-  --baseurl /dav \
-  --user "$webdavUsername" \
-  --pass "$webdavPassword"

test/shell/webdav-stop.sh

@@ -1,3 +0,0 @@
-#!/bin/bash
-docker stop webdav-test
-docker rm webdav-test

updates.md

@@ -3,12 +3,21 @@ Since 19th July, 2025 (beta1 in 0.25.0-beta1, 13th July, 2025)
 
 The head note of 0.25 is now in [updates_old.md](https://github.com/vrtmrz/obsidian-livesync/blob/main/updates_old.md). Because 0.25 got a lot of updates, thankfully, compatibility is kept and we do not need breaking changes! In other words, when get enough stabled. The next version will be v1.0.0. Even though it my hope.
 
-## Unreleased
+## 0.25.80
 
-### Experimental
+7th July, 2026
 
-- Added experimental WebDAV support for Journal synchronisation storage, including setup dialogue integration. This is currently a proof of concept for injecting Journal storage backends through the replication layer, and should be treated as an implementation experiment rather than a fully supported setup flow.
-- Hardened the WebDAV Journal storage proof of concept by centralising Journal storage adapter selection, improving connection checks, masking remote configuration descriptions, and verifying the Docker WebDAV integration path.
+### Fixed
+
+- Improved Markdown conflict auto-merge so that non-overlapping edits are merged while overlapping delete-and-edit cases remain visible for manual resolution (#993).
+  - Behaviour change:
+    - When one side deletes an unchanged line and the other side edits a different region, the deleted line is no longer reintroduced into the merged result.
+    - When one side deletes a line and the other side modifies that same line, the conflict is preserved instead of silently choosing one side.
+- Fixed an issue where applying a newer database entry to storage could incorrectly preserve an older local file as a conflict (#994).
+  - Behaviour change:
+    - Local storage is preserved as a conflict when it may contain unsynchronised changes that are not represented in the revision history. A newer incoming text entry is applied without creating a conflict only when it clearly extends the existing local text.
+- Fixed an issue where choosing Disable and then Overwrite in Hidden File Sync could silently skip hidden files, because the overwrite setup ran while hidden file synchronisation was still disabled (#989, PR #992).
+  - Hidden File Sync is now re-enabled before the Fetch, Overwrite, or Merge initialisation runs, instead of after it completes. If that initialisation fails, the setting may remain enabled.
 
 ## 0.25.79
 
@@ -103,41 +112,5 @@ Also, this update is a very large one, even if we had a lot of time, and we had
 - Some dependencies have been updated.
 - Now we check the compatibility with iOS 15 in the CI tests to ensure the plugin continues to work on older iOS versions even after we upgrade some dependencies.
 
-## 0.25.74
-
-8th June, 2026
-
-### Fixed
-
-- Fixed an issue where disabling hidden file synchronisation did not take effect, allowing non-target hidden files to continue to be processed and synchronised by replication or boot-sequence scan (#941).
-- Prevented the automatic merging of conflicted revisions when one of the revisions has been deleted, which was causing deleted files to reappear (#911).
-- The startup sequence now saves the state more effectively (Thank you so much for @bmcyver)!
-
-## Only CLI
-
-8th June, 2026
-
-I should also consider the version numbering for the CLI...
-
-### Improved
-
-- Added new remote database management commands: `remote-status`, `unlock-remote`, `lock-remote`, and `mark-resolved`.
-- --vault option is now available for daemon and mirror commands! (Thank you so much for @starskyzheng)!
-- Decoupled the database directory path from the actual vault directory path using the `--vault` (or `-V`) option.
-
-### Fixed (preventive)
-
-- Validated that the specified vault path exists and is indeed a directory before starting the CLI.
-- Integrated path resolution and validations for one-off commands (such as `'push'`, `'pull'`, `'cat'`, `'rm'`, `'info'`, and `'resolve'`) against the decoupled vault path instead of the database path.
-
-## 0.25.73
-
-4th June, 2026
-
-### Fixed
-
-- Adjust CouchDB's database name checking to its specification (#926).
-- `Reset Syncronisation on This Device` for minio and P2P is now working properly. 
-
 Full notes are in
 [updates_old.md](https://github.com/vrtmrz/obsidian-livesync/blob/main/updates_old.md).

updates_old.md

@@ -4,6 +4,64 @@ Since 19th July, 2025 (beta1 in 0.25.0-beta1, 13th July, 2025)
 The head note of 0.25 is now in [updates_old.md](https://github.com/vrtmrz/obsidian-livesync/blob/main/updates_old.md). Because 0.25 got a lot of updates, thankfully, compatibility is kept and we do not need breaking changes! In other words, when get enough stabled. The next version will be v1.0.0. Even though it my hope.
 
 
+## 0.25.80
+
+7th July, 2026
+
+### Fixed
+
+- Improved Markdown conflict auto-merge so that non-overlapping edits are merged while overlapping delete-and-edit cases remain visible for manual resolution (#993).
+  - Behaviour change:
+    - When one side deletes an unchanged line and the other side edits a different region, the deleted line is no longer reintroduced into the merged result.
+    - When one side deletes a line and the other side modifies that same line, the conflict is preserved instead of silently choosing one side.
+- Fixed an issue where applying a newer database entry to storage could incorrectly preserve an older local file as a conflict (#994).
+  - Behaviour change:
+    - Local storage is preserved as a conflict when it may contain unsynchronised changes that are not represented in the revision history. A newer incoming text entry is applied without creating a conflict only when it clearly extends the existing local text.
+- Fixed an issue where choosing Disable and then Overwrite in Hidden File Sync could silently skip hidden files, because the overwrite setup ran while hidden file synchronisation was still disabled (#989, PR #992).
+  - Hidden File Sync is now re-enabled before the Fetch, Overwrite, or Merge initialisation runs, instead of after it completes. If that initialisation fails, the setting may remain enabled.
+
+## 0.25.79
+
+29th June, 2026
+
+### Fixed
+
+- Fast Fetch now retries transient stream interruptions and resumes from the latest persisted checkpoint, instead of starting over after ordinary network or platform interruptions (#977, PR #978; commonlib PR #59). Thank you so much for @apple-ouyang for the fix!
+- Simple Fetch now remembers the selected setup choices while an interrupted Fetch All operation is still pending, so users are not asked the same questions again on retry (#977, PR #978). Thank you so much for @apple-ouyang for the fix!
+- No longer hidden storage events, such as `.git` paths, reach the normal target-file filter when internal file synchronisation is disabled. This avoids noisy non-target logs before those files are skipped (commonlib PR #60). Thank you so much for @apple-ouyang for the fix!
+- Fixed an issue where a file deleted from storage could be resurrected by the offline scanner because the database tombstone was not written when the storage file was already gone (commonlib PR #56). Thank you so much for @cosmic-fire-eng for the fix!
+
+### Improved
+
+- Local database maintenance commands now ask before applying the required chunk settings, and can apply those prerequisites before continuing (#980, PR #981). Thank you so much for @apple-ouyang for the improvement!
+- Improved CouchDB replication event handling by using the new `StreamInbox` helper from `octagonal-wheels` (commonlib PR #62).
+
+### Documentation
+
+- Added `nginx` to the setup documentation table of contents (PR #976). Thank you so much for @kiraventom for the improvement!
+
+### Miscellaneous
+
+- Updated `octagonal-wheels` to `0.1.47` across the plug-in and workspace packages to use the newly published helper modules.
+
+## 0.25.78
+
+23rd June, 2026
+
+### Fixed
+- No longer fast synchronisation (a.k.a. Fast Fetch) causes a rewind and re-fetch of the entire database when some errors occur during the process (#972, PR #973). Thank you so much for @apple-ouyang for the fix!
+
+### Improved
+
+- Overhauled the Object Storage (e.g., MinIO and S3) replication engine ('Journal Replicator 2nd Edition').
+  - It now leverages the standard Web Streams API for a resilient, backpressure-aware architecture, reducing memory footprints/temporary storage usage on large vaults.
+  - Decoupled the physical storage logic to make it easier to add new storage backends in the future.
+  - Stricter compliance with CouchDB's replication protocol (proper `_revisions` transfers with `new_edits: false`) when using Object Storage.
+
+### Testing
+  - Added comprehensive unit tests for the new `JournalSyncCore` engine, covering streams, backpressure, and `new_edits: false` validation.
+  - Improved integration test workflows in the CI pipeline to run MinIO tests automatically using standard environment variables.
+
 ## 0.25.77
 
 19th June, 2026