New feature:

- Add database configuration check & fixing tool

.eslintignore

@@ -0,0 +1,3 @@
+npm node_modules
+build
+.eslintrc.js.bak

.eslintrc

@@ -0,0 +1,19 @@
+{
+    "root": true,
+    "parser": "@typescript-eslint/parser",
+    "plugins": ["@typescript-eslint"],
+    "extends": ["eslint:recommended", "plugin:@typescript-eslint/eslint-recommended", "plugin:@typescript-eslint/recommended"],
+    "parserOptions": {
+        "sourceType": "module"
+    },
+    "rules": {
+        "no-unused-vars": "off",
+        "@typescript-eslint/no-unused-vars": ["error", { "args": "none" }],
+        "@typescript-eslint/ban-ts-comment": "off",
+        "no-prototype-builtins": "off",
+        "@typescript-eslint/no-empty-function": "off",
+        "require-await": "warn",
+        "no-async-promise-executor": "off",
+        "@typescript-eslint/no-explicit-any": "off"
+    }
+}

.github/FUNDING.yml

@@ -0,0 +1,3 @@
+# These are supported funding model platforms
+
+github: vrtmrz

.gitmodules

@@ -0,0 +1,3 @@
+[submodule "src/lib"]
+	path = src/lib
+	url = https://github.com/vrtmrz/livesync-commonlib

README.md

@@ -50,7 +50,7 @@ Especially, in some companies, people have to store all data to their fully cont
 2. Get your database. IBM Cloudant is preferred for testing. Or you can use your own server with CouchDB.
    For more information, refer below:
     1. [Setup IBM Cloudant](docs/setup_cloudant.md)
-    2. [Setup your CouchDB](docs/setup_own_server.md) (Now writing)
+    2. [Setup your CouchDB](docs/setup_own_server.md)
 3. Enter connection information to Plugin's setting dialog. In details, refer [Settings of Self-hosted LiveSync](docs/settings.md)
 4. Enable LiveSync or other Synchronize method as you like.
 
@@ -75,12 +75,15 @@ Synchronization status is shown in statusbar.
     -   ⚠ Error occurred.
 -   ↑ Uploaded pieces
 -   ↓ Downloaded pieces
+-   ⏳ Count of the pending process  
+If you have deleted or renamed files, please wait until this disappears.
 
 # More supplements
 
 -   When synchronized, files are compared by their modified times and overwritten by the newer ones once. Then plugin checks the conflicts and if a merge is needed, the dialog will open.
 -   Rarely, the file in the database would be broken. The plugin will not write storage when it looks broken, so some old files must be on your device. If you edit the file, it will be cured. But if the file does not exist on any device, can not rescue it. So you can delete these items from the setting dialog.
 -   If your database looks corrupted, try "Drop History". Usually, It is the easiest way.
+-   To stop the bootup sequence for fixing problems on databases, you can put `redflag.md` on top of your vault.
 -   Q: Database is growing, how can I shrink it up?
     A: each of the docs is saved with their old 100 revisions to detect and resolve confliction. Picture yourself that one device has been off the line for a while, and joined again. The device has to check his note and remote saved note. If exists in revision histories of remote notes even though the device's note is a little different from the latest one, it could be merged safely. Even if that is not in revision histories, we only have to check differences after the revision that both devices commonly have. This is like The git's conflict resolving method. So, We have to make the database again like an enlarged git repo if you want to solve the root of the problem.
 -   And more technical Information are in the [Technical Information](docs/tech_info.md)

README_ja.md

@@ -47,7 +47,7 @@ NDAや類似の契約や義務、倫理を守る必要のある、研究者、
 1. Community Pluginsから、Self-holsted LiveSyncと検索しインストールするか、このリポジトリのReleasesから`main.js`, `manifest.json`, `style.css` をダウンロードしvaultの中の`.obsidian/plugins/obsidian-livesync`に入れて、Obsidianを再起動してください。
 2. サーバーを確保します。IBM Cloudantがお手軽かつ堅牢で便利です。完全にセルフホストする際にはお持ちのサーバーにCouchDBをインストールする必要があります。詳しくは下記を参照してください
   1. [IBM Cloudantのセットアップ](docs/setup_cloudant_ja.md)
-  2. [独自のCouchDBのセットアップ](docs/setup_own_server_ja.md) (執筆中)
+  2. [独自のCouchDBのセットアップ](docs/setup_own_server_ja.md)
 3. サーバー情報を入力します。初回のみ、Obsidianを再起動することをオススメします。  
 設定内容の詳細は[このプラグインの設定](docs/settings_ja.md)を参照してください。
 
@@ -78,11 +78,14 @@ Self-hosted LiveSync用にWebClipperも作りました。Chrome Web Storeから
   - ⚠ エラーが発生しています
 - ↑ 送信したデータ数
 - ↓ 受信したデータ数
+-   ⏳ 保留している処理の数です  
+ファイルを削除したりリネームした場合、この表示が消えるまでお待ちください。
 
 # さらなる補足
 - ファイルは同期された後、タイムスタンプを比較して新しければいったん新しい方で上書きされます。その後、衝突が発生したかによって、マージが行われます。
 - まれにファイルが破損することがあります。破損したファイルに関してはディスクへの反映を試みないため、実際には使用しているデバイスには少し古いファイルが残っていることが多いです。そのファイルを再度更新してもらうと、データベースが更新されて問題なくなるケースがあります。ファイルがどの端末にも存在しない場合は、設定画面から、削除できます。
 - データベースが変。そういうときは、いったんデータベースをDrop Historyのapply and sendで再初期化してみてください。だいたい直ります。
+- データベースの復旧中に再起動した場合など、うまくローカルデータベースを修正できない際には、Vaultのトップに`redflag.md`というファイルを置いてください。起動時のシーケンスがスキップされます。
 - データベースが大きくなってきてるんだけど、小さくできる？→各ノートは、それぞれの古い100リビジョンとともに保存されています。例えば、しばらくオフラインだったあるデバイスが、久しぶりに同期したと想定してみてください。そのとき、そのデバイスは最新とは少し異なるリビジョンを持ってるはずです。その場合でも、リモートのリビジョン履歴にリモートのものが存在した場合、安全にマージできます。もしリビジョン履歴に存在しなかった場合、確認しなければいけない差分も、対象を存在して持っている共通のリビジョン以降のみに絞れます。ちょうどGitのような方法で、衝突を解決している形になるのです。そのため、肥大化したリポジトリの解消と同様に、本質的にデータベースを小さくしたい場合は、データベースの作り直しが必要です。
 - その他の技術的なお話は、[技術的な内容](docs/tech_info_ja.md)に書いてあります。
 

docs/settings.md

@@ -18,12 +18,19 @@ Note: This password is saved into your Obsidian's vault in plain text.
 The Database name to synchronize.  
 ⚠️If not exist, created automatically.
 
+
+### Use the old connecting method
+Since v0.8.0, Self-hosted LiveSync uses Obsidian's API to connect to the CouchDB instead of the browser API.
+This method will increase the performance and avoid troubles with the CORS.
+But it doesn't been well tested yet. If you are troubled, please disable this option once.
+
 ### Test Database connection
+You can check the connection by clicking this button.
 
 ## Local Database Configurations
 "Local Database" is created inside your obsidian.
 
-### Batch database update (beta)
+### Batch database update
 Delay database update until raise replication, open another file, window visibility changed, or file events except for file modification.  
 This option can not be used with LiveSync at the same time.
 
@@ -44,6 +51,8 @@ As a result, Obsidian's behavior is temporarily slowed down.
 Default is 300 seconds.
 If you are an early adopter, maybe this value is left as 30 seconds. Please change this value to larger values.
 
+Note: If you want to use "Use history", this vault must be set to 0.
+
 ### Manual Garbage Collect
 Run "Garbage Collection" manually.
 
@@ -52,6 +61,8 @@ Encrypt your database. It affects only the database, your files are left as plai
 
 The encryption algorithm is AES-GCM.
 
+Note: If you want to use "Plugins and their settings", you have to enable this.
+
 ### Passphrase
 The passphrase to used as the key of encryption. Please use the long text.
 
@@ -78,6 +89,27 @@ When running these operations, every synchronization settings is disabled.
 
 **And even your passphrase is wrong, It doesn't be checked before the plugin really decrypts. So If you set the wrong passphrase and run "Apply and Receive", you will get an amount of decryption error. But, this is the specification.**
 
+### minimum chunk size and LongLine threshold
+The configuration of chunk splitting.
+
+Self-hosted LiveSync splits the note into chunks for efficient synchronization. This chunk should be longer than "Minimum chunk size".
+
+Specifically, the length of the chunk is determined by the following orders.
+
+1. Find the nearest newline character, and if it is farther than LongLineThreshold, this piece becomes an independent chunk.
+
+2. If not, find nearest to these items.
+    1. Newline character
+    2. Empty line (Windows style)
+    3. Empty line (non-Windows style)
+3. Compare the farther in these 3 positions and next "\[newline\]#" position, pick a shorter piece to as chunk.
+
+This rule was made empirically from my dataset. If this rule acts as badly on your data. Please give me the information.
+
+You can dump saved note structure to `Dump informations of this doc`. Replace every character to x except newline and "#" when sending information to me.
+
+Default values are 20 letters and 250 letters.
+
 ## General Settings
 
 ### Do not show low-priority log
@@ -122,26 +154,80 @@ Self-hosted LiveSync will delete the folder when the folder becomes empty. If th
 ### Use newer file if conflicted (beta)
 Always use the newer file to resolve and overwrite when conflict has occurred.
 
-### minimum chunk size and LongLine threshold
-The configuration of chunk splitting.
+### Advanced settings
+Self-hosted LiveSync using PouchDB and synchronizes with the remote by [this protocol](https://docs.couchdb.org/en/stable/replication/protocol.html).
+So, it splits every entry into chunks to be acceptable by the database with limited payload size and document size.
 
-Self-hosted LiveSync splits the note into chunks for efficient synchronization. This chunk should be longer than "Minimum chunk size".
+However, it was not enough.
+According to [2.4.2.5.2. Upload Batch of Changed Documents](https://docs.couchdb.org/en/stable/replication/protocol.html#upload-batch-of-changed-documents) in [Replicate Changes](https://docs.couchdb.org/en/stable/replication/protocol.html#replicate-changes), it might become a bigger request.
 
-Specifically, the length of the chunk is determined by the following orders.
+Unfortunately, there is no way to deal with this automatically by size for every request.
+Therefore, I made it possible to configure this.
 
-1. Find the nearest newline character, and if it is farther than LongLineThreshold, this piece becomes an independent chunk.
+Note: If you set these values lower number, the number of requests will increase.  
+Therefore, if you are far from the server, the total throughput will be low, and the traffic will increase.
 
-2. If not, find nearest to these items.
-    1. Newline character
-    2. Empty line (Windows style)
-    3. Empty line (non-Windows style)
-3. Compare the farther in these 3 positions and next "\[newline\]#" position, pick a shorter piece to as chunk.
+### Batch size
+Number of change feed items to process at a time. Defaults to 250.
 
-This rule was made empirically from my dataset. If this rule acts as badly on your data. Please give me the information.
+### Batch limit
+Number of batches to process at a time. Defaults to 40. This along with batch size controls how many docs are kept in memory at a time.
 
-You can dump saved note structure to `Dump informations of this doc`. Replace every character to x except newline and "#" when sending information to me.
+## Miscellaneous
 
-Default values are 20 letters and 250 letters.
+### Show status inside editor
+Show information inside the editor pane.
+It would be useful for mobile.
+
+### Check integrity on saving
+Check all chunks are correctly saved on saving.
+
+### Presets
+You can set synchronization method at once as these pattern:
+- LiveSync
+  - LiveSync : enabled
+  - Batch database update : disabled
+  - Periodic Sync : disabled
+  - Sync on Save : disabled
+  - Sync on File Open : disabled
+  - Sync on Start : disabled
+- Periodic w/ batch
+  - LiveSync : disabled
+  - Batch database update : enabled
+  - Periodic Sync : enabled
+  - Sync on Save : disabled
+  - Sync on File Open : enabled
+  - Sync on Start : enabled
+- Disable all sync
+  - LiveSync : disabled
+  - Batch database update : disabled
+  - Periodic Sync : disabled
+  - Sync on Save : disabled
+  - Sync on File Open : disabled
+  - Sync on Start : disabled
+
+### Use history
+If you enable this option, you can keep document histories in your database.  
+(Not all intermediate changes are synchronized.)  
+You can check the changes caused by your edit and/or replication.
+
+### Enable plugin synchronization
+If you want to use this feature, you have to activate this feature by this switch.
+
+### Sweep plugins automatically
+Plugin sweep will run before replication automatically.
+
+### Sweep plugins periodically
+Plugin sweep will run each 1 minute.
+
+### Notify updates
+When replication is complete, a message will be notified if a newer version of the plugin applied to this device is configured on another device.
+
+### Device and Vault name
+To save the plugins, you have to set a unique name every each device.
+
+### Open
+Open the "Plugins and their settings" dialog.
 
 ## Hatch
 From here, everything is under the hood. Please handle it with care.
@@ -160,6 +246,12 @@ The remote database indicates that has been unlocked Pattern 1.
 When you mark all devices as resolved, you can unlock the database.
 But, there's no problem even if you leave it as it is.
 
+### Verify and repair all files
+read all files in the vault, and update them into the database if there's diff or could not read from the database.
+
+### Sanity check
+Make sure that all the files on the local database have all chunks.
+
 ### Drop history
 Drop all histories on the local database and the remote database, and initialize When synchronization time has been prolonged to the new device or new vault, or database size became to be much larger. Try this.
 

docs/settings_ja.md

@@ -25,7 +25,7 @@ CouchDBのURIを入力します。Cloudantの場合は「External Endpoint(prefe
 ## Local Database Configurations
 端末内に作成されるデータベースの設定です。
 
-### Batch database update (beta)
+### Batch database update
 データベースの更新を以下の事象が発生するまで遅延させます。
 - レプリケーションが発生する
 - 他のファイルを開く
@@ -78,6 +78,24 @@ End to End 暗号化を行うに当たって、異なるパスフレーズで暗
 どちらのオペレーションも、実行するとすべての同期設定が無効化されます。  
 **また、パスフレーズのチェックは、実際に復号するまで行いません。そのため、パスフレーズを間違えて設定し、Apply and receiveで同期を行うと、大量のエラーが発生します。これは仕様です。**
 
+### minimum chunk size と LongLine threshold
+チャンクの分割についての設定です。  
+Self-hosted LiveSyncは一つのチャンクのサイズを最低minimum chunk size文字確保した上で、できるだけ効率的に同期できるよう、ノートを分割してチャンクを作成します。  
+これは、同期を行う際に、一定の文字数で分割した場合、先頭の方を編集すると、その後の分割位置がすべてずれ、結果としてほぼまるごとのファイルのファイル送受信を行うことになっていた問題を避けるために実装されました。  
+具体的には、先頭から順に直近の下記の箇所を検索し、一番長く切れたものを一つのチャンクとします。
+
+1. 次の改行を探し、それがLongLine Thresholdより先であれば、一つのチャンクとして確定します。
+
+2. そうではない場合は、下記を順に探します。
+	1. 改行
+	2. windowsでの空行がある所
+	3. 非Windowsでの空行がある所
+3. この三つのうち一番遠い場所と、 「改行後、#から始まる所」を比べ、短い方をチャンクとします。
+
+このルールは経験則的に作りました。実データが偏っているため。もし思わぬ挙動をしている場合は、是非コマンドから`Dump informations of this doc`を選択し、情報をください。  
+改行文字と#を除き、すべて●に置換しても、アルゴリズムは有効に働きます。  
+デフォルトは20文字と、250文字です。
+
 ## General Settings
 一般的な設定です。
 
@@ -124,23 +142,33 @@ Self-hosted LiveSyncは通常、フォルダ内のファイルがすべて削除
 ### Use newer file if conflicted (beta)
 競合が発生したとき、常に新しいファイルを使用して競合を自動的に解決します。
 
-### minimum chunk size と LongLine threshold
-チャンクの分割についての設定です。  
-Self-hosted LiveSyncは一つのチャンクのサイズを最低minimum chunk size文字確保した上で、できるだけ効率的に同期できるよう、ノートを分割してチャンクを作成します。  
-これは、同期を行う際に、一定の文字数で分割した場合、先頭の方を編集すると、その後の分割位置がすべてずれ、結果としてほぼまるごとのファイルのファイル送受信を行うことになっていた問題を避けるために実装されました。  
-具体的には、先頭から順に直近の下記の箇所を検索し、一番長く切れたものを一つのチャンクとします。
+### Advanced settings
+Self-hosted LiveSyncはPouchDBを使用し、リモートと[このプロトコル](https://docs.couchdb.org/en/stable/replication/protocol.html)で同期しています。  
+そのため、全てのノートなどはデータベースが許容するペイロードサイズやドキュメントサイズに併せてチャンクに分割されています。
 
-1. 次の改行を探し、それがLongLine Thresholdより先であれば、一つのチャンクとして確定します。
+しかしながら、それだけでは不十分なケースがあり、[Replicate Changes](https://docs.couchdb.org/en/stable/replication/protocol.html#replicate-changes)の[2.4.2.5.2. Upload Batch of Changed Documents](https://docs.couchdb.org/en/stable/replication/protocol.html#upload-batch-of-changed-documents)を参照すると、このリクエストは巨大になる可能性がありました。
 
-2. そうではない場合は、下記を順に探します。
-	1. 改行
-	2. windowsでの空行がある所
-	3. 非Windowsでの空行がある所
-3. この三つのうち一番遠い場所と、 「改行後、#から始まる所」を比べ、短い方をチャンクとします。
+残念ながら、このサイズを呼び出しごとに自動的に調整する方法はありません。  
+そのため、設定を変更できるように機能追加いたしました。
+
+備考：もし小さな値を設定した場合、リクエスト数は増えます。  
+もしサーバから遠い場合、トータルのスループットは遅くなり、転送量は増えます。
+
+### Batch size
+一度に処理するChange feedの数です。デフォルトは250です。
+
+### Batch limit
+一度に処理するBatchの数です。デフォルトは40です。
+
+## Miscellaneous
+その他の設定です
+### Show status inside editor
+同期の情報をエディター内に表示します。  
+モバイルで便利です。
+
+### Check integrity on saving
+保存時にデータが全て保存できたかチェックを行います。
 
-このルールは経験則的に作りました。実データが偏っているため。もし思わぬ挙動をしている場合は、是非コマンドから`Dump informations of this doc`を選択し、情報をください。  
-改行文字と#を除き、すべて●に置換しても、アルゴリズムは有効に働きます。  
-デフォルトは20文字と、250文字です。
 
 ## Hatch
 ここから先は、困ったときに開ける蓋の中身です。注意して使用してください。
@@ -160,6 +188,12 @@ Self-hosted LiveSyncは一つのチャンクのサイズを最低minimum chunk s
 ご使用のすべてのデバイスでロックを解除した場合は、データベースのロックを解除することができます。  
 ただし、このまま放置しても問題はありません。
 
+### Verify and repair all files
+Vault内のファイルを全て読み込み直し、もし差分があったり、データベースから正常に読み込めなかったものに関して、データベースに反映します。
+
+### Sanity check
+ローカルデータベースに保存されている全てのファイルが正しくチャンクを持っていることを確認します。
+
 ### Drop history
 データベースに記録されている履歴を削除し、データベースを初期化します。  
 新しい端末や新しいVaultへの同期にやたらと時間がかかったり、データベースサイズが肥大化したりしてきた際に使用してください。  

docs/setup_own_server.md

@@ -1,3 +1,95 @@
 # Setup CouchDB to your server
 
-Coming soon!
+
+## Install CouchDB and access from PC or Mac
+
+The easiest way to set up the CouchDB is using the [docker image]((https://hub.docker.com/_/couchdb)).
+
+But some additional configurations are required in `local.ini` to use from Self-hosted LiveSync, like below:
+
+```
+[couchdb]
+single_node=true
+
+[chttpd]
+require_valid_user = true
+
+[chttpd_auth]
+require_valid_user = true
+authentication_redirect = /_utils/session.html
+
+[httpd]
+WWW-Authenticate = Basic realm="couchdb"
+enable_cors = true
+
+[cors]
+origins = app://obsidian.md,capacitor://localhost,http://localhost
+credentials = true
+headers = accept, authorization, content-type, origin, referer
+methods = GET, PUT, POST, HEAD, DELETE
+max_age = 3600
+```
+
+Make `local.ini` and run with docker run like this, you can launch the CouchDB.
+```
+$ docker run --rm -it -e COUCHDB_USER=admin -e COUCHDB_PASSWORD=password -v .local.ini:/opt/couchdb/etc/local.ini -p 5984:5984 couchdb
+```
+Note: At this time, the file owner of local.ini became 5984:5984. It's the limitation docker image. please change the owner before editing local.ini again.
+
+If you could confirm that Self-hosted LiveSync can sync with the server, launch docker image as background as you like.
+
+example)
+```
+$ docker run -d --restart always -e COUCHDB_USER=admin -e COUCHDB_PASSWORD=password -v .local.ini:/opt/couchdb/etc/local.ini -p 5984:5984 couchdb
+```
+
+## Access from mobile device
+If you want to access Self-hosted LiveSync from mobile devices, you need a valid SSL certificate.
+
+### Testing from mobile
+In the testing phase, [localhost.run](http://localhost.run/) or something like services is very useful.
+
+example on using localhost.run)
+```
+$ ssh -R 80:localhost:5984 nokey@localhost.run
+Warning: Permanently added the RSA host key for IP address '35.171.254.69' to the list of known hosts.
+
+===============================================================================
+Welcome to localhost.run!
+
+Follow your favourite reverse tunnel at [https://twitter.com/localhost_run].
+
+**You need a SSH key to access this service.**
+If you get a permission denied follow Gitlab's most excellent howto:
+https://docs.gitlab.com/ee/ssh/
+*Only rsa and ed25519 keys are supported*
+
+To set up and manage custom domains go to https://admin.localhost.run/
+
+More details on custom domains (and how to enable subdomains of your custom
+domain) at https://localhost.run/docs/custom-domains
+
+To explore using localhost.run visit the documentation site:
+https://localhost.run/docs/
+
+===============================================================================
+
+
+** your connection id is xxxxxxxxxxxxxxxxxxxxxxxxxxxx, please mention it if you send me a message about an issue. **
+
+xxxxxxxx.localhost.run tunneled with tls termination, https://xxxxxxxx.localhost.run
+Connection to localhost.run closed by remote host.
+Connection to localhost.run closed.
+```
+
+https://xxxxxxxx.localhost.run is the temporary server address.
+
+### Setting up your domain
+
+Set the A record of your domain to point to your server, and host reverse proxy as you like.  
+Note: Mounting CouchDB on the top directory is not recommended.  
+Using Caddy is a handy way to serve the server with SSL automatically.
+
+I have published [docker-compose.yml and ini files](https://github.com/vrtmrz/self-hosted-livesync-server) that launches Caddy and CouchDB at once. Please try it out.
+
+And, be sure to check the server log and be careful of malicious access.

docs/setup_own_server_ja.md

@@ -1,3 +1,91 @@
-# CouchDB のセットアップ方法
+# CouchDBのセットアップ方法
 
-早めに作成します！
+## CouchDBのインストールとPCやMacでの使用
+CouchDBを構築するには、[Dockerのイメージ](https://hub.docker.com/_/couchdb)を使用するのが一番簡単です。  
+ただし、インストールしたCouchDBをSelf-hosted LiveSyncから使用するためには、少々設定が必要となります。  
+具体的には、下記の設定が`local.ini`として必要になります。
+
+```
+[couchdb]
+single_node=true
+
+[chttpd]
+require_valid_user = true
+
+[chttpd_auth]
+require_valid_user = true
+authentication_redirect = /_utils/session.html
+
+[httpd]
+WWW-Authenticate = Basic realm="couchdb"
+enable_cors = true
+
+[cors]
+origins = app://obsidian.md,capacitor://localhost,http://localhost
+credentials = true
+headers = accept, authorization, content-type, origin, referer
+methods = GET, PUT, POST, HEAD, DELETE
+max_age = 3600
+```
+
+このファイルを作成し、
+```
+$ docker run --rm -it -e COUCHDB_USER=admin -e COUCHDB_PASSWORD=password -v .local.ini:/opt/couchdb/etc/local.ini -p 5984:5984 couchdb
+```
+とすると簡単にCouchDBを起動することができます。  
+備考：このとき、local.iniのオーナーが5984:5984になります。これは、Dockerイメージの制限事項です。編集する場合はいったんオーナーを変更してください。  
+正常にSelf-hosted LiveSyncからアクセスすることができたら、お好みでバックグラウンドで起動するように編集して起動してください。  
+例）  
+```
+$ docker run -d --restart always -e COUCHDB_USER=admin -e COUCHDB_PASSWORD=password -v .local.ini:/opt/couchdb/etc/local.ini -p 5984:5984 couchdb
+```
+
+
+## モバイルからのアクセス
+MacやPCからアクセスする場合は上記の方法で作ったサーバーで問題ありませんが、モバイル端末からアクセスする場合は有効なSSLの証明書が必要となります。
+
+### モバイルからのアクセスのテスト
+テストを行う場合は、[localhost.run](http://localhost.run/)などのサービスが便利です。
+```
+$ ssh -R 80:localhost:5984 nokey@localhost.run
+Warning: Permanently added the RSA host key for IP address '35.171.254.69' to the list of known hosts.
+
+===============================================================================
+Welcome to localhost.run!
+
+Follow your favourite reverse tunnel at [https://twitter.com/localhost_run].
+
+**You need a SSH key to access this service.**
+If you get a permission denied follow Gitlab's most excellent howto:
+https://docs.gitlab.com/ee/ssh/
+*Only rsa and ed25519 keys are supported*
+
+To set up and manage custom domains go to https://admin.localhost.run/
+
+More details on custom domains (and how to enable subdomains of your custom
+domain) at https://localhost.run/docs/custom-domains
+
+To explore using localhost.run visit the documentation site:
+https://localhost.run/docs/
+
+===============================================================================
+
+
+** your connection id is xxxxxxxxxxxxxxxxxxxxxxxxxxxx, please mention it if you send me a message about an issue. **
+
+xxxxxxxx.localhost.run tunneled with tls termination, https://xxxxxxxx.localhost.run
+Connection to localhost.run closed by remote host.
+Connection to localhost.run closed.
+```
+このように表示された場合、`https://xxxxxxxx.localhost.run`が一時的なサーバアドレスとして使用できます。
+
+### ドメインを設定してアクセスする。
+
+DNSのAレコードを設定し、お好みの方法でリバースプロキシをホスティングしてください。  
+備考:トップディレクトリにCouchDBを露出させるのはおすすめしません。  
+Caddy等でLet's Encryptの証明書を自動取得すると運用が楽になります。
+
+CaddyとCouchDBを同時に立てられる[docker-composeの設定とiniファイル](https://github.com/vrtmrz/self-hosted-livesync-server)を公開しています。
+ぜひご利用下さい。
+
+なお、サーバのログは必ず確認し、不正なアクセスに注意してください。

esbuild.config.mjs

@@ -0,0 +1,37 @@
+import esbuild from "esbuild";
+import process from "process";
+import builtins from "builtin-modules";
+import sveltePlugin from "esbuild-svelte";
+import sveltePreprocess from "svelte-preprocess";
+
+const banner = `/*
+THIS IS A GENERATED/BUNDLED FILE BY ESBUILD
+if you want to view the source, please visit the github repository of this plugin
+*/
+`;
+
+const prod = process.argv[2] === "production";
+
+esbuild
+    .build({
+        banner: {
+            js: banner,
+        },
+        entryPoints: ["src/main.ts"],
+        bundle: true,
+        external: ["obsidian", "electron", ...builtins],
+        format: "cjs",
+        watch: !prod,
+        target: "es2015",
+        logLevel: "info",
+        sourcemap: prod ? false : "inline",
+        treeShaking: true,
+        plugins: [
+            sveltePlugin({
+                preprocess: sveltePreprocess(),
+                compilerOptions: { css: true },
+            }),
+        ],
+        outfile: "main.js",
+    })
+    .catch(() => process.exit(1));

manifest.json

@@ -1,7 +1,7 @@
 {
     "id": "obsidian-livesync",
     "name": "Self-hosted LiveSync",
-    "version": "0.1.18",
+    "version": "0.9.0",
     "minAppVersion": "0.9.12",
     "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.json

@@ -1,11 +1,13 @@
 {
     "name": "obsidian-livesync",
-    "version": "0.1.18",
+    "version": "0.9.0",
     "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",
     "scripts": {
-        "dev": "rollup --config rollup.config.js -w",
-        "build": "rollup --config rollup.config.js --environment BUILD:production"
+        "dev": "node esbuild.config.mjs",
+        "build": "node esbuild.config.mjs production",
+        "lint": "eslint src"
     },
     "keywords": [],
     "author": "vorotamoroz",
@@ -15,14 +17,27 @@
         "@rollup/plugin-node-resolve": "^11.2.1",
         "@rollup/plugin-typescript": "^8.2.1",
         "@types/diff-match-patch": "^1.0.32",
+        "@types/pouchdb": "^6.4.0",
         "@types/pouchdb-browser": "^6.1.3",
-        "obsidian": "^0.12.0",
+        "@typescript-eslint/eslint-plugin": "^5.7.0",
+        "@typescript-eslint/parser": "^5.0.0",
+        "builtin-modules": "^3.2.0",
+        "esbuild": "0.13.12",
+        "esbuild-svelte": "^0.6.0",
+        "eslint": "^7.32.0",
+        "eslint-config-airbnb-base": "^14.2.1",
+        "eslint-plugin-import": "^2.25.2",
+        "obsidian": "^0.14.6",
         "rollup": "^2.32.1",
+        "svelte-preprocess": "^4.10.2",
         "tslib": "^2.2.0",
         "typescript": "^4.2.4"
     },
     "dependencies": {
         "diff-match-patch": "^1.0.5",
+        "esbuild": "0.13.12",
+        "esbuild-svelte": "^0.6.0",
+        "svelte-preprocess": "^4.10.2",
         "xxhash-wasm": "^0.4.2"
     }
 }

pouchdb-browser-webpack/README.md

@@ -1,2 +1,4 @@
 # PouchDB-browser
-just webpacked.
+
+Just webpacked.  
+(Rollup couldn't pack pouchdb-browser into browser bundle)

pouchdb-browser-webpack/package.json

@@ -14,7 +14,7 @@
   "author": "",
   "license": "ISC",
   "dependencies": {
-    "pouchdb-browser": "^7.2.2"
+    "pouchdb-browser": "^7.3.0"
   },
   "devDependencies": {
     "webpack": "^5.58.1",

rollup.config.js

@@ -11,7 +11,7 @@ if you want to view the source visit the plugins github repository
 `;
 
 export default {
-    input: "main.ts",
+    input: "./src/main.ts",
     output: {
         dir: ".",
         sourcemap: "inline",

src/ConflictResolveModal.ts

@@ -0,0 +1,81 @@
+import { App, Modal } from "obsidian";
+import { DIFF_DELETE, DIFF_EQUAL, DIFF_INSERT } from "diff-match-patch";
+import { diff_result } from "./lib/src/types";
+import { escapeStringToHTML } from "./lib/src/utils";
+
+export class ConflictResolveModal extends Modal {
+    // result: Array<[number, string]>;
+    result: diff_result;
+    callback: (remove_rev: string) => Promise<void>;
+
+    constructor(app: App, diff: diff_result, callback: (remove_rev: string) => Promise<void>) {
+        super(app);
+        this.result = diff;
+        this.callback = callback;
+    }
+
+    onOpen() {
+        const { contentEl } = this;
+
+        contentEl.empty();
+
+        contentEl.createEl("h2", { text: "This document has conflicted changes." });
+        const div = contentEl.createDiv("");
+        div.addClass("op-scrollable");
+        let diff = "";
+        for (const v of this.result.diff) {
+            const x1 = v[0];
+            const x2 = v[1];
+            if (x1 == DIFF_DELETE) {
+                diff += "<span class='deleted'>" + escapeStringToHTML(x2) + "</span>";
+            } else if (x1 == DIFF_EQUAL) {
+                diff += "<span class='normal'>" + escapeStringToHTML(x2) + "</span>";
+            } else if (x1 == DIFF_INSERT) {
+                diff += "<span class='added'>" + escapeStringToHTML(x2) + "</span>";
+            }
+        }
+
+        diff = diff.replace(/\n/g, "<br>");
+        div.innerHTML = diff;
+        const div2 = contentEl.createDiv("");
+        const date1 = new Date(this.result.left.mtime).toLocaleString();
+        const date2 = new Date(this.result.right.mtime).toLocaleString();
+        div2.innerHTML = `
+<span class='deleted'>A:${date1}</span><br /><span class='added'>B:${date2}</span><br> 
+        `;
+        contentEl.createEl("button", { text: "Keep A" }, (e) => {
+            e.addEventListener("click", async () => {
+                await this.callback(this.result.right.rev);
+                this.callback = null;
+                this.close();
+            });
+        });
+        contentEl.createEl("button", { text: "Keep B" }, (e) => {
+            e.addEventListener("click", async () => {
+                await this.callback(this.result.left.rev);
+                this.callback = null;
+                this.close();
+            });
+        });
+        contentEl.createEl("button", { text: "Concat both" }, (e) => {
+            e.addEventListener("click", async () => {
+                await this.callback("");
+                this.callback = null;
+                this.close();
+            });
+        });
+        contentEl.createEl("button", { text: "Not now" }, (e) => {
+            e.addEventListener("click", () => {
+                this.close();
+            });
+        });
+    }
+
+    onClose() {
+        const { contentEl } = this;
+        contentEl.empty();
+        if (this.callback != null) {
+            this.callback(null);
+        }
+    }
+}

src/DocumentHistoryModal.ts

@@ -0,0 +1,146 @@
+import { TFile, Modal, App } from "obsidian";
+import { path2id } from "./utils";
+import { escapeStringToHTML } from "./lib/src/utils";
+import ObsidianLiveSyncPlugin from "./main";
+import { DIFF_DELETE, DIFF_EQUAL, DIFF_INSERT, diff_match_patch } from "diff-match-patch";
+import { LOG_LEVEL } from "./lib/src/types";
+import { Logger } from "./lib/src/logger";
+
+export class DocumentHistoryModal extends Modal {
+    plugin: ObsidianLiveSyncPlugin;
+    range: HTMLInputElement;
+    contentView: HTMLDivElement;
+    info: HTMLDivElement;
+    fileInfo: HTMLDivElement;
+    showDiff = false;
+
+    file: string;
+
+    revs_info: PouchDB.Core.RevisionInfo[] = [];
+    currentText = "";
+
+    constructor(app: App, plugin: ObsidianLiveSyncPlugin, file: TFile) {
+        super(app);
+        this.plugin = plugin;
+        this.file = file.path;
+        if (localStorage.getItem("ols-history-highlightdiff") == "1") {
+            this.showDiff = true;
+        }
+    }
+    async loadFile() {
+        const db = this.plugin.localDatabase;
+        const w = await db.localDatabase.get(path2id(this.file), { revs_info: true });
+        this.revs_info = w._revs_info.filter((e) => e.status == "available");
+        this.range.max = `${this.revs_info.length - 1}`;
+        this.range.value = this.range.max;
+        this.fileInfo.setText(`${this.file} / ${this.revs_info.length} revisions`);
+        await this.loadRevs();
+    }
+    async loadRevs() {
+        const db = this.plugin.localDatabase;
+        const index = this.revs_info.length - 1 - (this.range.value as any) / 1;
+        const rev = this.revs_info[index];
+        const w = await db.getDBEntry(path2id(this.file), { rev: rev.rev }, false, false);
+        this.currentText = "";
+
+        if (w === false) {
+            this.info.innerHTML = "";
+            this.contentView.innerHTML = `Could not read this revision<br>(${rev.rev})`;
+        } else {
+            this.info.innerHTML = `Modified:${new Date(w.mtime).toLocaleString()}`;
+            let result = "";
+            this.currentText = w.data;
+            if (this.showDiff) {
+                const prevRevIdx = this.revs_info.length - 1 - ((this.range.value as any) / 1 - 1);
+                if (prevRevIdx >= 0 && prevRevIdx < this.revs_info.length) {
+                    const oldRev = this.revs_info[prevRevIdx].rev;
+                    const w2 = await db.getDBEntry(path2id(this.file), { rev: oldRev }, false, false);
+                    if (w2 != false) {
+                        const dmp = new diff_match_patch();
+                        const diff = dmp.diff_main(w2.data, w.data);
+                        dmp.diff_cleanupSemantic(diff);
+                        for (const v of diff) {
+                            const x1 = v[0];
+                            const x2 = v[1];
+                            if (x1 == DIFF_DELETE) {
+                                result += "<span class='history-deleted'>" + escapeStringToHTML(x2) + "</span>";
+                            } else if (x1 == DIFF_EQUAL) {
+                                result += "<span class='history-normal'>" + escapeStringToHTML(x2) + "</span>";
+                            } else if (x1 == DIFF_INSERT) {
+                                result += "<span class='history-added'>" + escapeStringToHTML(x2) + "</span>";
+                            }
+                        }
+
+                        result = result.replace(/\n/g, "<br>");
+                    } else {
+                        result = escapeStringToHTML(w.data);
+                    }
+                } else {
+                    result = escapeStringToHTML(w.data);
+                }
+            } else {
+                result = escapeStringToHTML(w.data);
+            }
+            this.contentView.innerHTML = result;
+        }
+    }
+
+    onOpen() {
+        const { contentEl } = this;
+
+        contentEl.empty();
+        contentEl.createEl("h2", { text: "Document History" });
+        this.fileInfo = contentEl.createDiv("");
+        this.fileInfo.addClass("op-info");
+        const divView = contentEl.createDiv("");
+        divView.addClass("op-flex");
+
+        divView.createEl("input", { type: "range" }, (e) => {
+            this.range = e;
+            e.addEventListener("change", (e) => {
+                this.loadRevs();
+            });
+            e.addEventListener("input", (e) => {
+                this.loadRevs();
+            });
+        });
+        contentEl
+            .createDiv("", (e) => {
+                e.createEl("label", {}, (label) => {
+                    label.appendChild(
+                        createEl("input", { type: "checkbox" }, (checkbox) => {
+                            if (this.showDiff) {
+                                checkbox.checked = true;
+                            }
+                            checkbox.addEventListener("input", (evt: any) => {
+                                this.showDiff = checkbox.checked;
+                                localStorage.setItem("ols-history-highlightdiff", this.showDiff == true ? "1" : "");
+                                this.loadRevs();
+                            });
+                        })
+                    );
+                    label.appendText("Highlight diff");
+                });
+            })
+            .addClass("op-info");
+        this.info = contentEl.createDiv("");
+        this.info.addClass("op-info");
+        this.loadFile();
+        const div = contentEl.createDiv({ text: "Loading old revisions..." });
+        this.contentView = div;
+        div.addClass("op-scrollable");
+        div.addClass("op-pre");
+        const buttons = contentEl.createDiv("");
+        buttons.createEl("button", { text: "Copy to clipboard" }, (e) => {
+            e.addClass("mod-cta");
+            e.addEventListener("click", async () => {
+                await navigator.clipboard.writeText(this.currentText);
+                Logger(`Old content copied to clipboard`, LOG_LEVEL.NOTICE);
+            });
+        });
+    }
+    onClose() {
+        const { contentEl } = this;
+        contentEl.empty();
+    }
+}

src/LogDisplayModal.ts

@@ -0,0 +1,37 @@
+import { App, Modal } from "obsidian";
+import { escapeStringToHTML } from "./lib/src/utils";
+import ObsidianLiveSyncPlugin from "./main";
+
+export class LogDisplayModal extends Modal {
+    plugin: ObsidianLiveSyncPlugin;
+    logEl: HTMLDivElement;
+    constructor(app: App, plugin: ObsidianLiveSyncPlugin) {
+        super(app);
+        this.plugin = plugin;
+    }
+    updateLog() {
+        let msg = "";
+        for (const v of this.plugin.logMessage) {
+            msg += escapeStringToHTML(v) + "<br>";
+        }
+        this.logEl.innerHTML = msg;
+    }
+    onOpen() {
+        const { contentEl } = this;
+
+        contentEl.empty();
+        contentEl.createEl("h2", { text: "Sync Status" });
+        const div = contentEl.createDiv("");
+        div.addClass("op-scrollable");
+        div.addClass("op-pre");
+        this.logEl = div;
+        this.updateLog = this.updateLog.bind(this);
+        this.plugin.addLogHook = this.updateLog;
+        this.updateLog();
+    }
+    onClose() {
+        const { contentEl } = this;
+        contentEl.empty();
+        this.plugin.addLogHook = null;
+    }
+}

src/PluginPane.svelte

@@ -0,0 +1,290 @@
+<script lang="ts">
+    import ObsidianLiveSyncPlugin from "./main";
+    import { onMount } from "svelte";
+    import { DevicePluginList, PluginDataEntry } from "./types";
+    import { versionNumberString2Number } from "./lib/src/utils";
+
+    type JudgeResult = "" | "NEWER" | "EVEN" | "EVEN_BUT_DIFFERENT" | "OLDER" | "REMOTE_ONLY";
+
+    interface PluginDataEntryDisp extends PluginDataEntry {
+        versionInfo: string;
+        mtimeInfo: string;
+        mtimeFlag: JudgeResult;
+        versionFlag: JudgeResult;
+    }
+
+    export let plugin: ObsidianLiveSyncPlugin;
+    let plugins: PluginDataEntry[] = [];
+    let deviceAndPlugins: { [key: string]: PluginDataEntryDisp[] } = {};
+    let devicePluginList: [string, PluginDataEntryDisp[]][] = [];
+    let ownPlugins: DevicePluginList = null;
+    let showOwnPlugins = false;
+    let targetList: { [key: string]: boolean } = {};
+
+    function saveTargetList() {
+        window.localStorage.setItem("ols-plugin-targetlist", JSON.stringify(targetList));
+    }
+
+    function loadTargetList() {
+        let e = window.localStorage.getItem("ols-plugin-targetlist") || "{}";
+        try {
+            targetList = JSON.parse(e);
+        } catch (_) {
+            // NO OP.
+        }
+    }
+
+    function clearSelection() {
+        targetList = {};
+    }
+
+    async function updateList() {
+        let x = await plugin.getPluginList();
+        ownPlugins = x.thisDevicePlugins;
+        plugins = Object.values(x.allPlugins);
+        let targetListItems = Array.from(new Set(plugins.map((e) => e.deviceVaultName + "---" + e.manifest.id)));
+        let newTargetList: { [key: string]: boolean } = {};
+        for (const id of targetListItems) {
+            for (const tag of ["---plugin", "---setting"]) {
+                newTargetList[id + tag] = id + tag in targetList && targetList[id + tag];
+            }
+        }
+        targetList = newTargetList;
+        saveTargetList();
+    }
+
+    $: {
+        deviceAndPlugins = {};
+        for (const p of plugins) {
+            if (p.deviceVaultName == plugin.deviceAndVaultName && !showOwnPlugins) {
+                continue;
+            }
+            if (!(p.deviceVaultName in deviceAndPlugins)) {
+                deviceAndPlugins[p.deviceVaultName] = [];
+            }
+            let dispInfo: PluginDataEntryDisp = { ...p, versionInfo: "", mtimeInfo: "", versionFlag: "", mtimeFlag: "" };
+            dispInfo.versionInfo = p.manifest.version;
+            let x = new Date().getTime() / 1000;
+            let mtime = p.mtime / 1000;
+            let diff = (x - mtime) / 60;
+            if (p.mtime == 0) {
+                dispInfo.mtimeInfo = `-`;
+            } else if (diff < 60) {
+                dispInfo.mtimeInfo = `${diff | 0} Mins ago`;
+            } else if (diff < 60 * 24) {
+                dispInfo.mtimeInfo = `${(diff / 60) | 0} Hours ago`;
+            } else if (diff < 60 * 24 * 10) {
+                dispInfo.mtimeInfo = `${(diff / (60 * 24)) | 0} Days ago`;
+            } else {
+                dispInfo.mtimeInfo = new Date(dispInfo.mtime).toLocaleString();
+            }
+            // compare with own plugin
+            let id = p.manifest.id;
+
+            if (id in ownPlugins) {
+                // Which we have.
+                const ownPlugin = ownPlugins[id];
+                let localVer = versionNumberString2Number(ownPlugin.manifest.version);
+                let pluginVer = versionNumberString2Number(p.manifest.version);
+                if (localVer > pluginVer) {
+                    dispInfo.versionFlag = "OLDER";
+                } else if (localVer == pluginVer) {
+                    if (ownPlugin.manifestJson + (ownPlugin.styleCss ?? "") + ownPlugin.mainJs != p.manifestJson + (p.styleCss ?? "") + p.mainJs) {
+                        dispInfo.versionFlag = "EVEN_BUT_DIFFERENT";
+                    } else {
+                        dispInfo.versionFlag = "EVEN";
+                    }
+                } else if (localVer < pluginVer) {
+                    dispInfo.versionFlag = "NEWER";
+                }
+                if ((ownPlugin.dataJson ?? "") == (p.dataJson ?? "")) {
+                    if (ownPlugin.mtime == 0 && p.mtime == 0) {
+                        dispInfo.mtimeFlag = "";
+                    } else {
+                        dispInfo.mtimeFlag = "EVEN";
+                    }
+                } else {
+                    if (((ownPlugin.mtime / 1000) | 0) > ((p.mtime / 1000) | 0)) {
+                        dispInfo.mtimeFlag = "OLDER";
+                    } else if (((ownPlugin.mtime / 1000) | 0) == ((p.mtime / 1000) | 0)) {
+                        dispInfo.mtimeFlag = "EVEN_BUT_DIFFERENT";
+                    } else if (((ownPlugin.mtime / 1000) | 0) < ((p.mtime / 1000) | 0)) {
+                        dispInfo.mtimeFlag = "NEWER";
+                    }
+                }
+            } else {
+                dispInfo.versionFlag = "REMOTE_ONLY";
+                dispInfo.mtimeFlag = "REMOTE_ONLY";
+            }
+
+            deviceAndPlugins[p.deviceVaultName].push(dispInfo);
+        }
+        devicePluginList = Object.entries(deviceAndPlugins);
+    }
+
+    function getDispString(stat: JudgeResult): string {
+        if (stat == "") return "";
+        if (stat == "NEWER") return " (Newer)";
+        if (stat == "OLDER") return " (Older)";
+        if (stat == "EVEN") return " (Even)";
+        if (stat == "EVEN_BUT_DIFFERENT") return " (Even but different)";
+        if (stat == "REMOTE_ONLY") return " (Remote Only)";
+        return "";
+    }
+
+    onMount(async () => {
+        loadTargetList();
+        await updateList();
+    });
+
+    function toggleShowOwnPlugins() {
+        showOwnPlugins = !showOwnPlugins;
+    }
+
+    function toggleTarget(key: string) {
+        targetList[key] = !targetList[key];
+        saveTargetList();
+    }
+
+    function toggleAll(devicename: string) {
+        for (const c in targetList) {
+            if (c.startsWith(devicename)) {
+                targetList[c] = true;
+            }
+        }
+    }
+
+    async function sweepPlugins() {
+        //@ts-ignore
+        await plugin.app.plugins.loadManifests();
+        await plugin.sweepPlugin(true);
+        updateList();
+    }
+
+    async function applyPlugins() {
+        for (const c in targetList) {
+            if (targetList[c] == true) {
+                const [deviceAndVault, id, opt] = c.split("---");
+                if (deviceAndVault in deviceAndPlugins) {
+                    const entry = deviceAndPlugins[deviceAndVault].find((e) => e.manifest.id == id);
+                    if (entry) {
+                        if (opt == "plugin") {
+                            if (entry.versionFlag != "EVEN") await plugin.applyPlugin(entry);
+                        } else if (opt == "setting") {
+                            if (entry.mtimeFlag != "EVEN") await plugin.applyPluginData(entry);
+                        }
+                    }
+                }
+            }
+        }
+        //@ts-ignore
+        await plugin.app.plugins.loadManifests();
+        await plugin.sweepPlugin(true);
+        updateList();
+    }
+
+    async function checkUpdates() {
+        await plugin.checkPluginUpdate();
+    }
+    async function replicateAndRefresh() {
+        await plugin.replicate(true);
+        updateList();
+    }
+</script>
+
+<div>
+    <h1>Plugins and their settings</h1>
+    <div class="ols-plugins-div-buttons">
+        Show own items
+        <div class="checkbox-container" class:is-enabled={showOwnPlugins} on:click={toggleShowOwnPlugins} />
+    </div>
+    <div class="sls-plugins-wrap">
+        <table class="sls-plugins-tbl">
+            <tr style="position:sticky">
+                <th class="sls-plugins-tbl-device-head">Name</th>
+                <th class="sls-plugins-tbl-device-head">Info</th>
+                <th class="sls-plugins-tbl-device-head">Target</th>
+            </tr>
+            {#if devicePluginList.length == 0}
+                <tr>
+                    <td colspan="3" class="sls-table-tail tcenter"> Retrieving... </td>
+                </tr>
+            {/if}
+            {#each devicePluginList as [deviceName, devicePlugins]}
+                <tr>
+                    <th colspan="2" class="sls-plugins-tbl-device-head">{deviceName}</th>
+                    <th class="sls-plugins-tbl-device-head">
+                        <button class="mod-cta" on:click={() => toggleAll(deviceName)}>✔</button>
+                    </th>
+                </tr>
+                {#each devicePlugins as plugin}
+                    <tr>
+                        <td class="sls-table-head">{plugin.manifest.name}</td>
+                        <td class="sls-table-tail tcenter">{plugin.versionInfo}{getDispString(plugin.versionFlag)}</td>
+                        <td class="sls-table-tail tcenter">
+                            {#if plugin.versionFlag === "EVEN" || plugin.versionFlag === ""}
+                                -
+                            {:else}
+                                <div class="wrapToggle">
+                                    <div
+                                        class="checkbox-container"
+                                        class:is-enabled={targetList[plugin.deviceVaultName + "---" + plugin.manifest.id + "---plugin"]}
+                                        on:click={() => toggleTarget(plugin.deviceVaultName + "---" + plugin.manifest.id + "---plugin")}
+                                    />
+                                </div>
+                            {/if}
+                        </td>
+                    </tr>
+                    <tr>
+                        <td class="sls-table-head">Settings</td>
+                        <td class="sls-table-tail tcenter">{plugin.mtimeInfo}{getDispString(plugin.mtimeFlag)}</td>
+                        <td class="sls-table-tail tcenter">
+                            {#if plugin.mtimeFlag === "EVEN" || plugin.mtimeFlag === ""}
+                                -
+                            {:else}
+                                <div class="wrapToggle">
+                                    <div
+                                        class="checkbox-container"
+                                        class:is-enabled={targetList[plugin.deviceVaultName + "---" + plugin.manifest.id + "---setting"]}
+                                        on:click={() => toggleTarget(plugin.deviceVaultName + "---" + plugin.manifest.id + "---setting")}
+                                    />
+                                </div>
+                            {/if}
+                        </td>
+                    </tr>
+                    <tr class="divider">
+                        <th colspan="3" />
+                    </tr>
+                {/each}
+            {/each}
+        </table>
+    </div>
+    <div class="ols-plugins-div-buttons">
+        <button class="" on:click={replicateAndRefresh}>Replicate and refresh</button>
+        <button class="" on:click={clearSelection}>Clear Selection</button>
+    </div>
+
+    <div class="ols-plugins-div-buttons">
+        <button class="mod-cta" on:click={checkUpdates}>Check Updates</button>
+        <button class="mod-cta" on:click={sweepPlugins}>Scan installed</button>
+        <button class="mod-cta" on:click={applyPlugins}>Apply all</button>
+    </div>
+    <!--    <div class="ols-plugins-div-buttons">-->
+    <!--        <button class="mod-warning" on:click={applyPlugins}>Delete all selected</button>-->
+    <!--    </div>-->
+</div>
+
+<style>
+    .ols-plugins-div-buttons {
+        display: flex;
+        flex-direction: row;
+        justify-content: flex-end;
+        margin-top: 8px;
+    }
+
+    .wrapToggle {
+        display: flex;
+        justify-content: center;
+        align-content: center;
+    }
+</style>

src/pouchdb-browser.ts

@@ -0,0 +1,4 @@
+import { PouchDB as PouchDB_ } from "../pouchdb-browser-webpack/dist/pouchdb-browser.js";
+
+const Pouch: PouchDB.Static = PouchDB_;
+export { Pouch as PouchDB };

src/types.ts

@@ -0,0 +1,24 @@
+import { PluginManifest } from "obsidian";
+import { DatabaseEntry } from "./lib/src/types";
+
+export interface PluginDataEntry extends DatabaseEntry {
+    deviceVaultName: string;
+    mtime: number;
+    manifest: PluginManifest;
+    mainJs: string;
+    manifestJson: string;
+    styleCss?: string;
+    // it must be encrypted.
+    dataJson?: string;
+    _conflicts?: string[];
+    type: "plugin";
+}
+
+export interface PluginList {
+    [key: string]: PluginDataEntry[];
+}
+
+export interface DevicePluginList {
+    [key: string]: PluginDataEntry;
+}
+export const PERIODIC_PLUGIN_SWEEP = 60;

src/utils.ts

@@ -0,0 +1,14 @@
+import { normalizePath } from "obsidian";
+
+import { path2id_base, id2path_base } from "./lib/src/utils";
+
+// For backward compatibility, using the path for determining id.
+// Only CouchDB nonacceptable ID (that starts with an underscore) has been prefixed with "/".
+// The first slash will be deleted when the path is normalized.
+export function path2id(filename: string): string {
+    const x = normalizePath(filename);
+    return path2id_base(x);
+}
+export function id2path(filename: string): string {
+    return id2path_base(normalizePath(filename));
+}

src/utils_couchdb.ts

@@ -0,0 +1,181 @@
+import { Logger } from "./lib/src/logger";
+import { LOG_LEVEL, VER, VERSIONINFO_DOCID, EntryVersionInfo, EntryDoc } from "./lib/src/types";
+import { resolveWithIgnoreKnownError } from "./lib/src/utils";
+import { PouchDB } from "./pouchdb-browser";
+import { requestUrl, RequestUrlParam, RequestUrlResponse } from "obsidian";
+
+export const isValidRemoteCouchDBURI = (uri: string): boolean => {
+    if (uri.startsWith("https://")) return true;
+    if (uri.startsWith("http://")) return true;
+    return false;
+};
+let last_post_successed = false;
+export const getLastPostFailedBySize = () => {
+    return !last_post_successed;
+};
+const fetchByAPI = async (request: RequestUrlParam): Promise<RequestUrlResponse> => {
+    const ret = await requestUrl(request);
+    if (ret.status - (ret.status % 100) !== 200) {
+        const er: Error & { status?: number } = new Error(`Request Error:${ret.status}`);
+        if (ret.json) {
+            er.message = ret.json.reason;
+            er.name = `${ret.json.error ?? ""}:${ret.json.message ?? ""}`;
+        }
+        er.status = ret.status;
+        throw er;
+    }
+    return ret;
+};
+
+export const connectRemoteCouchDB = async (uri: string, auth: { username: string; password: string }, disableRequestURI: boolean): Promise<string | { db: PouchDB.Database<EntryDoc>; info: PouchDB.Core.DatabaseInfo }> => {
+    if (!isValidRemoteCouchDBURI(uri)) return "Remote URI is not valid";
+    let authHeader = "";
+    if (auth.username && auth.password) {
+        const utf8str = String.fromCharCode.apply(null, new TextEncoder().encode(`${auth.username}:${auth.password}`));
+        const encoded = window.btoa(utf8str);
+        authHeader = "Basic " + encoded;
+    } else {
+        authHeader = "";
+    }
+    const conf: PouchDB.HttpAdapter.HttpAdapterConfiguration = {
+        adapter: "http",
+        auth,
+        fetch: async function (url: string | Request, opts: RequestInit) {
+            let size = "";
+            const localURL = url.toString().substring(uri.length);
+            const method = opts.method ?? "GET";
+            if (opts.body) {
+                const opts_length = opts.body.toString().length;
+                if (opts_length > 1024 * 1024 * 10) {
+                    // over 10MB
+                    if (uri.contains(".cloudantnosqldb.")) {
+                        last_post_successed = false;
+                        Logger("This request should fail on IBM Cloudant.", LOG_LEVEL.VERBOSE);
+                        throw new Error("This request should fail on IBM Cloudant.");
+                    }
+                }
+                size = ` (${opts_length})`;
+            }
+
+            if (!disableRequestURI && typeof url == "string" && typeof (opts.body ?? "") == "string") {
+                const body = opts.body as string;
+
+                const transformedHeaders = { ...(opts.headers as Record<string, string>) };
+                if (authHeader != "") transformedHeaders["authorization"] = authHeader;
+                delete transformedHeaders["host"];
+                delete transformedHeaders["Host"];
+                delete transformedHeaders["content-length"];
+                delete transformedHeaders["Content-Length"];
+                const requestParam: RequestUrlParam = {
+                    url: url as string,
+                    method: opts.method,
+                    body: body,
+                    headers: transformedHeaders,
+                    contentType: "application/json",
+                    // contentType: opts.headers,
+                };
+
+                try {
+                    const r = await fetchByAPI(requestParam);
+                    if (method == "POST" || method == "PUT") {
+                        last_post_successed = r.status - (r.status % 100) == 200;
+                    } else {
+                        last_post_successed = true;
+                    }
+                    Logger(`HTTP:${method}${size} to:${localURL} -> ${r.status}`, LOG_LEVEL.VERBOSE);
+
+                    return new Response(r.arrayBuffer, {
+                        headers: r.headers,
+                        status: r.status,
+                        statusText: `${r.status}`,
+                    });
+                } catch (ex) {
+                    Logger(`HTTP:${method}${size} to:${localURL} -> failed`, LOG_LEVEL.VERBOSE);
+                    // limit only in bulk_docs.
+                    if (url.toString().indexOf("_bulk_docs") !== -1) {
+                        last_post_successed = false;
+                    }
+                    Logger(ex);
+                    throw ex;
+                }
+            }
+
+            // -old implementation
+
+            try {
+                const responce: Response = await fetch(url, opts);
+                if (method == "POST" || method == "PUT") {
+                    last_post_successed = responce.ok;
+                } else {
+                    last_post_successed = true;
+                }
+                Logger(`HTTP:${method}${size} to:${localURL} -> ${responce.status}`, LOG_LEVEL.VERBOSE);
+                return responce;
+            } catch (ex) {
+                Logger(`HTTP:${method}${size} to:${localURL} -> failed`, LOG_LEVEL.VERBOSE);
+                // limit only in bulk_docs.
+                if (url.toString().indexOf("_bulk_docs") !== -1) {
+                    last_post_successed = false;
+                }
+                Logger(ex);
+                throw ex;
+            }
+            // return await fetch(url, opts);
+        },
+    };
+    const db: PouchDB.Database<EntryDoc> = new PouchDB<EntryDoc>(uri, conf);
+    try {
+        const info = await db.info();
+        return { db: db, info: info };
+    } catch (ex) {
+        let msg = `${ex.name}:${ex.message}`;
+        if (ex.name == "TypeError" && ex.message == "Failed to fetch") {
+            msg += "\n**Note** This error caused by many reasons. The only sure thing is you didn't touch the server.\nTo check details, open inspector.";
+        }
+        Logger(ex, LOG_LEVEL.VERBOSE);
+        return msg;
+    }
+};
+// check the version of remote.
+// if remote is higher than current(or specified) version, return false.
+export const checkRemoteVersion = async (db: PouchDB.Database, migrate: (from: number, to: number) => Promise<boolean>, barrier: number = VER): Promise<boolean> => {
+    try {
+        const versionInfo = (await db.get(VERSIONINFO_DOCID)) as EntryVersionInfo;
+        if (versionInfo.type != "versioninfo") {
+            return false;
+        }
+
+        const version = versionInfo.version;
+        if (version < barrier) {
+            const versionUpResult = await migrate(version, barrier);
+            if (versionUpResult) {
+                await bumpRemoteVersion(db);
+                return true;
+            }
+        }
+        if (version == barrier) return true;
+        return false;
+    } catch (ex) {
+        if (ex.status && ex.status == 404) {
+            if (await bumpRemoteVersion(db)) {
+                return true;
+            }
+            return false;
+        }
+        throw ex;
+    }
+};
+export const bumpRemoteVersion = async (db: PouchDB.Database, barrier: number = VER): Promise<boolean> => {
+    const vi: EntryVersionInfo = {
+        _id: VERSIONINFO_DOCID,
+        version: barrier,
+        type: "versioninfo",
+    };
+    const versionInfo = (await resolveWithIgnoreKnownError(db.get(VERSIONINFO_DOCID), vi)) as EntryVersionInfo;
+    if (versionInfo.type != "versioninfo") {
+        return false;
+    }
+    vi._rev = versionInfo._rev;
+    await db.put(vi);
+    return true;
+};

styles.css

@@ -28,3 +28,163 @@
     -webkit-filter: grayscale(100%);
     filter: grayscale(100%);
 }
+.tcenter {
+    text-align: center;
+}
+.sls-plugins-wrap {
+    display: flex;
+    flex-grow: 1;
+    max-height: 50vh;
+    overflow-y: scroll;
+}
+.sls-plugins-tbl {
+    border: 1px solid var(--background-modifier-border);
+    width: 100%;
+    max-height: 80%;
+}
+.divider th {
+    border-top: 1px solid var(--background-modifier-border);
+}
+/* .sls-table-head{
+    width:50%;
+}
+.sls-table-tail{
+    width:50%;
+
+} */
+
+.sls-btn-left {
+    padding-right: 4px;
+}
+.sls-btn-right {
+    padding-left: 4px;
+}
+.sls-hidden {
+    display: none;
+}
+
+:root {
+    --slsmessage: "";
+}
+.CodeMirror-wrap::before,
+.cm-s-obsidian > .cm-editor::before {
+    content: var(--slsmessage);
+    position: absolute;
+    border-radius: 4px;
+    /* border:1px solid --background-modifier-border; */
+    display: inline-block;
+    top: 8px;
+    color: --text-normal;
+    opacity: 0.5;
+    font-size: 80%;
+    -webkit-filter: grayscale(100%);
+    filter: grayscale(100%);
+}
+
+.CodeMirror-wrap::before {
+    right: 0px;
+}
+.cm-s-obsidian > .cm-editor::before {
+    right: 16px;
+}
+.sls-setting-tab {
+    display: none;
+}
+div.sls-setting-menu-btn {
+    color: var(--text-normal);
+    background-color: var(--background-secondary-alt);
+    border-radius: 4px 4px 0 0;
+    padding: 6px 10px;
+    cursor: pointer;
+    margin-right: 12px;
+    font-family: "Inter", sans-serif;
+    outline: none;
+    user-select: none;
+    flex-grow: 1;
+    text-align: center;
+    flex-shrink: 1;
+}
+
+.sls-setting-label.selected {
+    /* order: 1; */
+    flex-grow: 1;
+    /* width: 100%; */
+}
+.sls-setting-tab:hover ~ div.sls-setting-menu-btn,
+.sls-setting-tab:checked ~ div.sls-setting-menu-btn {
+    background-color: var(--interactive-accent);
+    color: var(--text-on-accent);
+}
+
+.sls-setting-menu {
+    display: flex;
+    flex-direction: row;
+    /* flex-wrap: wrap; */
+    overflow-x: auto;
+}
+.sls-setting-label {
+    flex-grow: 1;
+    display: inline-flex;
+    justify-content: center;
+}
+.setting-collapsed {
+    display: none;
+}
+.sls-plugins-tbl-buttons {
+    text-align: right;
+}
+
+.sls-plugins-tbl-buttons button {
+    flex-grow: 0;
+    padding: 6px 10px;
+}
+.sls-plugins-tbl-device-head {
+    background-color: var(--background-secondary-alt);
+    color: var(--text-accent);
+}
+.op-flex {
+    display: flex;
+}
+.op-flex input {
+    display: inline-flex;
+    flex-grow: 1;
+    margin-bottom: 8px;
+}
+
+.op-info {
+    display: inline-flex;
+    flex-grow: 1;
+    border-bottom: 1px solid var(--background-modifier-border);
+    width: 100%;
+    margin-bottom: 4px;
+    padding-bottom: 4px;
+}
+
+.history-added {
+    color: var(--text-on-accent);
+    background-color: var(--text-accent);
+}
+.history-normal {
+    color: var(--text-normal);
+}
+.history-deleted {
+    color: var(--text-on-accent);
+    background-color: var(--text-muted);
+    text-decoration: line-through;
+}
+
+.ob-btn-config-fix label {
+    margin-right: 40px;
+}
+.ob-btn-config-info {
+    border: 1px solid salmon;
+    padding: 2px;
+    margin: 1px;
+    border-radius: 4px;
+}
+
+.ob-btn-config-head {
+    padding: 2px;
+    margin: 1px;
+    border-radius: 4px;
+}

tsconfig.json

@@ -1,17 +1,16 @@
 {
     "compilerOptions": {
         "baseUrl": ".",
-        "inlineSourceMap": true,
-        "inlineSources": true,
         "module": "ESNext",
-        "target": "es6",
+        "target": "ES6",
         "allowJs": true,
         "noImplicitAny": true,
         "moduleResolution": "node",
+        // "importsNotUsedAsValues": "error",
         "importHelpers": true,
-        "lib": ["dom", "es5", "scripthost", "es2015"]
+        "alwaysStrict": true,
+        "lib": ["es2018", "DOM", "ES5", "ES6", "ES7"]
     },
     "include": ["**/*.ts"],
-    "files": ["./main.ts"],
     "exclude": ["pouchdb-browser-webpack"]
 }