Compare commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
b6bae792c6 | ||
|
|
8624141780 | ||
|
|
563c2c3ff6 | ||
|
|
9a72ac8d66 | ||
|
|
d980bcbc1b | ||
|
|
6ebe1a8966 | ||
|
|
d0ab1d8abe | ||
|
|
b86d116830 | ||
|
|
7d5eaad36f | ||
|
|
7a13f4566c | ||
|
|
d355f72b7a | ||
|
|
9b1eebdf90 | ||
|
|
2ce461ed6a | ||
|
|
3aa91a2a1e | ||
|
|
2a3e0524c5 | ||
|
|
2f20ca61ce | ||
|
|
68ec8b5454 | ||
|
|
2bbbd569c5 | ||
|
|
62936c4473 | ||
|
|
789d07261e | ||
|
|
ccd3b49b4b | ||
|
|
2930fe5350 | ||
|
|
a9abf6d834 | ||
|
|
bdf09e24c3 | ||
|
|
8dc4b835c9 | ||
|
|
2e800af4f8 | ||
|
|
e9e9e2b6eb | ||
|
|
274e0b8b28 | ||
|
|
2147332cf4 | ||
|
|
262bb9a1fe | ||
|
|
2669a3e8ad | ||
|
|
bdac16ee24 | ||
|
|
0a7de6588a | ||
|
|
1effcdd7f7 | ||
|
|
00c840a758 | ||
|
|
2eb1545f9d | ||
|
|
0d75ea92b1 | ||
|
|
d6cbf4260a | ||
|
|
9389039c7a |
@@ -13,6 +13,8 @@ jobs:
|
|||||||
build:
|
build:
|
||||||
runs-on: ubuntu-latest
|
runs-on: ubuntu-latest
|
||||||
|
|
||||||
|
environment: env-for-buildci
|
||||||
|
|
||||||
strategy:
|
strategy:
|
||||||
matrix:
|
matrix:
|
||||||
node-version: [16.x]
|
node-version: [16.x]
|
||||||
|
|||||||
@@ -4,15 +4,18 @@ This is yet another unofficial sync plugin for Obsidian.
|
|||||||
|
|
||||||
## Disclaimer
|
## Disclaimer
|
||||||
|
|
||||||
- **This is NOT the [official sync service](https://github.com/fyears/obsidian-remotely-save.git) provided by Obsidian.**
|
- **This is NOT the [official sync service](https://obsidian.md/sync) provided by Obsidian.**
|
||||||
|
|
||||||
## !!!Caution!!!
|
## !!!Caution!!!
|
||||||
|
|
||||||
As of November 2021, the plugin is considered in BETA stage. **DO NOT USE IT for any serious vaults.** **Backup your vault before using this plugin.** Don't be surprise to data loss!
|
As of Dec 2021, the plugin is considered in BETA stage. **DO NOT USE IT for any serious vaults.** **ALWAYS, ALWAYS, backup your vault before using this plugin.**
|
||||||
|
|
||||||
## Features
|
## Features
|
||||||
|
|
||||||
- **Amazon S3 or S3-compatible services are supported.** Webdav supports on the half way.
|
- Supports:
|
||||||
|
- Amazon S3 or S3-compatible
|
||||||
|
- Dropbox
|
||||||
|
- Webdav
|
||||||
- **Obsidiain Mobile supported.** Vaults can be synced across mobile and desktop devices with the cloud service as the "broker".
|
- **Obsidiain Mobile supported.** Vaults can be synced across mobile and desktop devices with the cloud service as the "broker".
|
||||||
- **[End-to-end encryption](./docs/encryption.md) supported.** Files would be encrypted using openssl format before being sent to the cloud **if** user specify a password.
|
- **[End-to-end encryption](./docs/encryption.md) supported.** Files would be encrypted using openssl format before being sent to the cloud **if** user specify a password.
|
||||||
- **[Minimal Intrusive](./docs/minimal_intrusive_design.md).**
|
- **[Minimal Intrusive](./docs/minimal_intrusive_design.md).**
|
||||||
@@ -27,15 +30,25 @@ As of November 2021, the plugin is considered in BETA stage. **DO NOT USE IT for
|
|||||||
- **Cloud services cost you money.** Always be aware of the costs and pricing.
|
- **Cloud services cost you money.** Always be aware of the costs and pricing.
|
||||||
- **All files or folder starting with `.` (dot) or `_` (underscore) are treated as hidden files, and would NOT be synced.** It's useful if you have some files just staying locally. But this strategy also means that themes / other plugins / settings of this plugin would neither be synced.
|
- **All files or folder starting with `.` (dot) or `_` (underscore) are treated as hidden files, and would NOT be synced.** It's useful if you have some files just staying locally. But this strategy also means that themes / other plugins / settings of this plugin would neither be synced.
|
||||||
|
|
||||||
|
## Questions, Suggestions, Or Bugs
|
||||||
|
|
||||||
|
You are greatly welcome to ask questions, post any suggestions, or report any bugs! The project is mainly maintained on GitHub:
|
||||||
|
|
||||||
|
- Questions: [GitHub repo Discussions](https://github.com/fyears/remotely-save/discussions)
|
||||||
|
- Suggestions: also in [GitHub repo Discussions](https://github.com/fyears/remotely-save/discussions)
|
||||||
|
- Bugs: [GitHub repo Issues](https://github.com/fyears/remotely-save/issues) (NOT Discussion)
|
||||||
|
|
||||||
|
Additionally, the plugin author may occasionally visit Obsidian official forum and official Discord server, and pay attention to this-plugin-related information there.
|
||||||
|
|
||||||
## Download and Install
|
## Download and Install
|
||||||
|
|
||||||
- Option #1: [](https://github.com/fyears/obsidian-remotely-save/actions/workflows/auto-build.yml) Every artifacts are placed in the "Summary" under every successful builds.
|
- Option #1: You can search, download, and install the plugin in official "community plugin list".
|
||||||
- Option #2: Besides manually downloading the files, you can also use [Obsidian42 - BRAT](https://github.com/TfTHacker/obsidian42-brat) to install this plugin.
|
- Option #2: [](https://github.com/fyears/remotely-save/actions/workflows/auto-build.yml) Every artifacts are placed in the "Summary" under every successful builds.
|
||||||
- Option #3: The pluin would be submitted to the official "community plugin list" in near future.
|
- Option #3: Besides manually downloading the files, you can also use [Obsidian42 - BRAT](https://github.com/TfTHacker/obsidian42-brat) to install this plugin.
|
||||||
|
|
||||||
## Usage
|
## Usage
|
||||||
|
|
||||||
### s3
|
### S3
|
||||||
|
|
||||||
- Prepare your S3 (-compatible) service information: [endpoint, region](https://docs.aws.amazon.com/general/latest/gr/s3.html), [access key id, secret access key](https://docs.aws.amazon.com/sdk-for-javascript/v3/developer-guide/getting-your-credentials.html), bucket name. The bucket should be empty and solely for syncing a vault.
|
- Prepare your S3 (-compatible) service information: [endpoint, region](https://docs.aws.amazon.com/general/latest/gr/s3.html), [access key id, secret access key](https://docs.aws.amazon.com/sdk-for-javascript/v3/developer-guide/getting-your-credentials.html), bucket name. The bucket should be empty and solely for syncing a vault.
|
||||||
- Configure (enable) [CORS](https://docs.aws.amazon.com/AmazonS3/latest/userguide/enabling-cors-examples.html) for requests from `app://obsidian.md` and `capacitor://localhost` and `http://localhost`. It's unfortunately required, because the plugin sends requests from a browser-like envirement. And those addresses are tested and found on desktop and ios and android.
|
- Configure (enable) [CORS](https://docs.aws.amazon.com/AmazonS3/latest/userguide/enabling-cors-examples.html) for requests from `app://obsidian.md` and `capacitor://localhost` and `http://localhost`. It's unfortunately required, because the plugin sends requests from a browser-like envirement. And those addresses are tested and found on desktop and ios and android.
|
||||||
@@ -45,8 +58,19 @@ As of November 2021, the plugin is considered in BETA stage. **DO NOT USE IT for
|
|||||||
- Click the new "switch" icon on the ribbon (the left sidebar), **every time** you want to sync your vault between local and remote. (No "auto sync" yet.)
|
- Click the new "switch" icon on the ribbon (the left sidebar), **every time** you want to sync your vault between local and remote. (No "auto sync" yet.)
|
||||||
- **Be patient while syncing.** Especially in the first-time sync.
|
- **Be patient while syncing.** Especially in the first-time sync.
|
||||||
|
|
||||||
|
### Dropbox
|
||||||
|
|
||||||
|
- **This plugin's function for Dropbox is not as mature as functions for S3.**
|
||||||
|
- **This plugin is NOT an official Dropbox product.** The plugin just uses Dropbox's public API.
|
||||||
|
- After the authorization, the plugin can read your name and email (which cannot be unselected on Dropbox api), and read and write files in your Dropbox's `/Apps/remotely-save` folder.
|
||||||
|
- If you decide to authorize this plugin to connect to Dropbox, please go to plugin's settings, and choose Dropbox then follow the instructions.
|
||||||
|
- Password-based end-to-end encryption is also supported.
|
||||||
|
|
||||||
### webdav
|
### webdav
|
||||||
|
|
||||||
- **webdav support is buggy (as of now, 20211122) and considered experimental, so it's hidden by default.** Highly recommend to use the more stable s3.
|
- **webdav support is considered experimental.**
|
||||||
- If you decide to give it a try, open settings, and click "Choose service" area five times, then a Notice should show up. Close and open settings again then you will be able to select webdav.
|
- Currently only supports BASIC authorization method.
|
||||||
- Currently webdav server should enable CORS for requests, because of technical limitations of mobile.
|
- Currently webdav server has to be enabled CORS for requests from `app://obsidian.md` and `capacitor://localhost` and `http://localhost`, **AND** all webdav HTTP methods, **AND** all webdav headers. These are required, because Obsidian mobile works like a browser and mobile plugins are limited by CORS policies.
|
||||||
|
- Popular software NextCloud and OwnCloud do **NOT** enable CORS by default. If you are using any of them, you should evaluate the risk, and find a way to enable CORS, before using this plugin.
|
||||||
|
- The plugin is tested successfully under python package [`wsgidav` (version 4.0)](https://github.com/mar10/wsgidav). See [this issue](https://github.com/mar10/wsgidav/issues/239) for some details.
|
||||||
|
- Password-based end-to-end encryption is also supported.
|
||||||
|
|||||||
@@ -0,0 +1,42 @@
|
|||||||
|
import dotenv from "dotenv/config";
|
||||||
|
import esbuild from "esbuild";
|
||||||
|
import process from "process";
|
||||||
|
// import builtins from 'builtin-modules'
|
||||||
|
|
||||||
|
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";
|
||||||
|
|
||||||
|
const DEFAULT_DROPBOX_APP_KEY = process.env.DROPBOX_APP_KEY || "";
|
||||||
|
|
||||||
|
esbuild
|
||||||
|
.build({
|
||||||
|
banner: {
|
||||||
|
js: banner,
|
||||||
|
},
|
||||||
|
entryPoints: ["./src/main.ts"],
|
||||||
|
bundle: true,
|
||||||
|
external: [
|
||||||
|
"obsidian",
|
||||||
|
"electron",
|
||||||
|
"fs",
|
||||||
|
"crypto",
|
||||||
|
// ...builtins
|
||||||
|
],
|
||||||
|
format: "cjs",
|
||||||
|
watch: !prod,
|
||||||
|
target: "es2016",
|
||||||
|
logLevel: "info",
|
||||||
|
sourcemap: prod ? false : "inline",
|
||||||
|
treeShaking: true,
|
||||||
|
minify: prod,
|
||||||
|
outfile: "main.js",
|
||||||
|
define: {
|
||||||
|
"process.env.DEFAULT_DROPBOX_APP_KEY": `"${DEFAULT_DROPBOX_APP_KEY}"`,
|
||||||
|
},
|
||||||
|
})
|
||||||
|
.catch(() => process.exit(1));
|
||||||
+3
-3
@@ -1,9 +1,9 @@
|
|||||||
{
|
{
|
||||||
"id": "obsidian-remotely-save",
|
"id": "remotely-save",
|
||||||
"name": "Remotely Save",
|
"name": "Remotely Save",
|
||||||
"version": "0.1.6",
|
"version": "0.2.3",
|
||||||
"minAppVersion": "0.12.15",
|
"minAppVersion": "0.12.15",
|
||||||
"description": "Yet another unofficial plugin allowing users to sync notes between local device and the cloud service.",
|
"description": "Yet another unofficial plugin allowing users to synchronize notes between local device and the cloud service.",
|
||||||
"author": "fyears",
|
"author": "fyears",
|
||||||
"authorUrl": "https://github.com/fyears",
|
"authorUrl": "https://github.com/fyears",
|
||||||
"isDesktopOnly": false
|
"isDesktopOnly": false
|
||||||
|
|||||||
+19
-5
@@ -1,14 +1,20 @@
|
|||||||
{
|
{
|
||||||
"name": "obsidian-remotely-save",
|
"name": "remotely-save",
|
||||||
"version": "0.1.6",
|
"version": "0.2.3",
|
||||||
"description": "This is yet another sync plugin for Obsidian app.",
|
"description": "This is yet another sync plugin for Obsidian app.",
|
||||||
"scripts": {
|
"scripts": {
|
||||||
"dev": "webpack --mode development --watch",
|
"dev": "node esbuild.config.mjs",
|
||||||
|
"build2": "tsc -noEmit -skipLibCheck && node esbuild.config.mjs production",
|
||||||
"build": "webpack --mode production",
|
"build": "webpack --mode production",
|
||||||
"format": "npx prettier --write .",
|
"format": "npx prettier --write .",
|
||||||
"clean": "npx rimraf main.js",
|
"clean": "npx rimraf main.js",
|
||||||
"test": "cross-env TS_NODE_COMPILER_OPTIONS={\\\"module\\\":\\\"commonjs\\\"} mocha -r ts-node/register 'tests/**/*.ts'"
|
"test": "cross-env TS_NODE_COMPILER_OPTIONS={\\\"module\\\":\\\"commonjs\\\"} mocha -r ts-node/register 'tests/**/*.ts'"
|
||||||
},
|
},
|
||||||
|
"browser": {
|
||||||
|
"path": "path-browserify",
|
||||||
|
"process": "process/browser",
|
||||||
|
"stream": "stream-browserify"
|
||||||
|
},
|
||||||
"source": "main.ts",
|
"source": "main.ts",
|
||||||
"keywords": [],
|
"keywords": [],
|
||||||
"author": "",
|
"author": "",
|
||||||
@@ -19,18 +25,21 @@
|
|||||||
"@types/mime-types": "^2.1.1",
|
"@types/mime-types": "^2.1.1",
|
||||||
"@types/mocha": "^9.0.0",
|
"@types/mocha": "^9.0.0",
|
||||||
"@types/node": "^14.14.37",
|
"@types/node": "^14.14.37",
|
||||||
|
"@types/qrcode": "^1.4.1",
|
||||||
|
"builtin-modules": "^3.2.0",
|
||||||
"chai": "^4.3.4",
|
"chai": "^4.3.4",
|
||||||
"chai-as-promised": "^7.1.1",
|
"chai-as-promised": "^7.1.1",
|
||||||
"cross-env": "^7.0.3",
|
"cross-env": "^7.0.3",
|
||||||
|
"dotenv": "^10.0.0",
|
||||||
|
"esbuild": "^0.14.0",
|
||||||
"mocha": "^9.1.3",
|
"mocha": "^9.1.3",
|
||||||
"prettier": "^2.4.1",
|
"prettier": "^2.4.1",
|
||||||
"terser-webpack-plugin": "^5.2.4",
|
|
||||||
"ts-loader": "^9.2.6",
|
"ts-loader": "^9.2.6",
|
||||||
"ts-node": "^10.4.0",
|
"ts-node": "^10.4.0",
|
||||||
"tslib": "^2.2.0",
|
"tslib": "^2.2.0",
|
||||||
"typescript": "^4.4.4",
|
"typescript": "^4.4.4",
|
||||||
"webdav-server": "^2.6.2",
|
"webdav-server": "^2.6.2",
|
||||||
"webpack": "^5.58.2",
|
"webpack": "^5.64.4",
|
||||||
"webpack-cli": "^4.9.1"
|
"webpack-cli": "^4.9.1"
|
||||||
},
|
},
|
||||||
"dependencies": {
|
"dependencies": {
|
||||||
@@ -38,17 +47,22 @@
|
|||||||
"@aws-sdk/lib-storage": "^3.40.1",
|
"@aws-sdk/lib-storage": "^3.40.1",
|
||||||
"@aws-sdk/signature-v4-crt": "^3.37.0",
|
"@aws-sdk/signature-v4-crt": "^3.37.0",
|
||||||
"acorn": "^8.5.0",
|
"acorn": "^8.5.0",
|
||||||
|
"assert": "^2.0.0",
|
||||||
"aws-crt": "^1.10.1",
|
"aws-crt": "^1.10.1",
|
||||||
"buffer": "^6.0.3",
|
"buffer": "^6.0.3",
|
||||||
"codemirror": "^5.63.1",
|
"codemirror": "^5.63.1",
|
||||||
|
"crypto-browserify": "^3.12.0",
|
||||||
|
"dropbox": "^10.22.0",
|
||||||
"localforage": "^1.10.0",
|
"localforage": "^1.10.0",
|
||||||
"mime-types": "^2.1.33",
|
"mime-types": "^2.1.33",
|
||||||
"obsidian": "^0.12.0",
|
"obsidian": "^0.12.0",
|
||||||
"path-browserify": "^1.0.1",
|
"path-browserify": "^1.0.1",
|
||||||
"process": "^0.11.10",
|
"process": "^0.11.10",
|
||||||
|
"qrcode": "^1.5.0",
|
||||||
"rfc4648": "^1.5.0",
|
"rfc4648": "^1.5.0",
|
||||||
"rimraf": "^3.0.2",
|
"rimraf": "^3.0.2",
|
||||||
"stream-browserify": "^3.0.0",
|
"stream-browserify": "^3.0.0",
|
||||||
|
"util": "^0.12.4",
|
||||||
"webdav": "^4.7.0",
|
"webdav": "^4.7.0",
|
||||||
"webdav-fs": "^4.0.0",
|
"webdav-fs": "^4.0.0",
|
||||||
"xregexp": "^5.1.0"
|
"xregexp": "^5.1.0"
|
||||||
|
|||||||
+47
-1
@@ -1,8 +1,44 @@
|
|||||||
/**
|
/**
|
||||||
* Only type defs here.
|
* Only type defs here.
|
||||||
|
* To avoid circular dependency.
|
||||||
*/
|
*/
|
||||||
|
|
||||||
export type SUPPORTED_SERVICES_TYPE = "s3" | "webdav";
|
export type SUPPORTED_SERVICES_TYPE = "s3" | "webdav" | "dropbox";
|
||||||
|
|
||||||
|
export interface S3Config {
|
||||||
|
s3Endpoint: string;
|
||||||
|
s3Region: string;
|
||||||
|
s3AccessKeyID: string;
|
||||||
|
s3SecretAccessKey: string;
|
||||||
|
s3BucketName: string;
|
||||||
|
}
|
||||||
|
|
||||||
|
export interface DropboxConfig {
|
||||||
|
accessToken: string;
|
||||||
|
clientID: string;
|
||||||
|
refreshToken: string;
|
||||||
|
accessTokenExpiresInSeconds: number;
|
||||||
|
accessTokenExpiresAtTime: number;
|
||||||
|
accountID: string;
|
||||||
|
username: string;
|
||||||
|
}
|
||||||
|
|
||||||
|
export type WebdavAuthType = "digest" | "basic";
|
||||||
|
|
||||||
|
export interface WebdavConfig {
|
||||||
|
address: string;
|
||||||
|
username: string;
|
||||||
|
password: string;
|
||||||
|
authType: WebdavAuthType;
|
||||||
|
}
|
||||||
|
|
||||||
|
export interface RemotelySavePluginSettings {
|
||||||
|
s3: S3Config;
|
||||||
|
webdav: WebdavConfig;
|
||||||
|
dropbox: DropboxConfig;
|
||||||
|
password: string;
|
||||||
|
serviceType: SUPPORTED_SERVICES_TYPE;
|
||||||
|
}
|
||||||
|
|
||||||
export interface RemoteItem {
|
export interface RemoteItem {
|
||||||
key: string;
|
key: string;
|
||||||
@@ -11,3 +47,13 @@ export interface RemoteItem {
|
|||||||
remoteType: SUPPORTED_SERVICES_TYPE;
|
remoteType: SUPPORTED_SERVICES_TYPE;
|
||||||
etag?: string;
|
etag?: string;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
export const COMMAND_URI = "remotely-save";
|
||||||
|
export const COMMAND_CALLBACK = "remotely-save-cb";
|
||||||
|
|
||||||
|
export interface UriParams {
|
||||||
|
func?: string;
|
||||||
|
vault?: string;
|
||||||
|
ver?: string;
|
||||||
|
data?: string;
|
||||||
|
}
|
||||||
|
|||||||
@@ -0,0 +1,76 @@
|
|||||||
|
import QRCode from "qrcode";
|
||||||
|
|
||||||
|
import {
|
||||||
|
COMMAND_URI,
|
||||||
|
UriParams,
|
||||||
|
RemotelySavePluginSettings,
|
||||||
|
} from "./baseTypes";
|
||||||
|
|
||||||
|
export const exportQrCodeUri = async (
|
||||||
|
settings: RemotelySavePluginSettings,
|
||||||
|
currentVaultName: string,
|
||||||
|
pluginVersion: string
|
||||||
|
) => {
|
||||||
|
const data = encodeURIComponent(JSON.stringify(settings));
|
||||||
|
const vault = encodeURIComponent(currentVaultName);
|
||||||
|
const version = encodeURIComponent(pluginVersion);
|
||||||
|
const rawUri = `obsidian://${COMMAND_URI}?func=settings&version=${version}&vault=${vault}&data=${data}`;
|
||||||
|
// console.log(uri)
|
||||||
|
const imgUri = await QRCode.toDataURL(rawUri);
|
||||||
|
return {
|
||||||
|
rawUri,
|
||||||
|
imgUri,
|
||||||
|
};
|
||||||
|
};
|
||||||
|
|
||||||
|
export interface ProcessQrCodeResultType {
|
||||||
|
status: "error" | "ok";
|
||||||
|
message: string;
|
||||||
|
result?: RemotelySavePluginSettings;
|
||||||
|
}
|
||||||
|
|
||||||
|
export const importQrCodeUri = (
|
||||||
|
inputParams: any,
|
||||||
|
currentVaultName: string
|
||||||
|
): ProcessQrCodeResultType => {
|
||||||
|
let params = inputParams as UriParams;
|
||||||
|
if (
|
||||||
|
params.func === undefined ||
|
||||||
|
params.func !== "settings" ||
|
||||||
|
params.vault === undefined ||
|
||||||
|
params.data === undefined
|
||||||
|
) {
|
||||||
|
return {
|
||||||
|
status: "error",
|
||||||
|
message: `the uri is not for exporting/importing settings: ${JSON.stringify(
|
||||||
|
inputParams
|
||||||
|
)}`,
|
||||||
|
};
|
||||||
|
}
|
||||||
|
|
||||||
|
if (params.vault !== currentVaultName) {
|
||||||
|
return {
|
||||||
|
status: "error",
|
||||||
|
message: `the target vault is ${
|
||||||
|
params.vault
|
||||||
|
} but you are currently in ${currentVaultName}: ${JSON.stringify(
|
||||||
|
inputParams
|
||||||
|
)}`,
|
||||||
|
};
|
||||||
|
}
|
||||||
|
|
||||||
|
let settings = {} as RemotelySavePluginSettings;
|
||||||
|
try {
|
||||||
|
settings = JSON.parse(params.data);
|
||||||
|
} catch (e) {
|
||||||
|
return {
|
||||||
|
status: "error",
|
||||||
|
message: `errors while parsing settings: ${JSON.stringify(inputParams)}`,
|
||||||
|
};
|
||||||
|
}
|
||||||
|
return {
|
||||||
|
status: "ok",
|
||||||
|
message: "ok",
|
||||||
|
result: settings,
|
||||||
|
};
|
||||||
|
};
|
||||||
+370
-62
@@ -11,6 +11,7 @@ import {
|
|||||||
TFolder,
|
TFolder,
|
||||||
} from "obsidian";
|
} from "obsidian";
|
||||||
import * as CodeMirror from "codemirror";
|
import * as CodeMirror from "codemirror";
|
||||||
|
import process from "process";
|
||||||
import {
|
import {
|
||||||
prepareDBs,
|
prepareDBs,
|
||||||
destroyDBs,
|
destroyDBs,
|
||||||
@@ -25,26 +26,36 @@ import type { InternalDBs } from "./localdb";
|
|||||||
|
|
||||||
import type { SyncStatusType, PasswordCheckType } from "./sync";
|
import type { SyncStatusType, PasswordCheckType } from "./sync";
|
||||||
import { isPasswordOk, getSyncPlan, doActualSync } from "./sync";
|
import { isPasswordOk, getSyncPlan, doActualSync } from "./sync";
|
||||||
import { S3Config, DEFAULT_S3_CONFIG } from "./s3";
|
|
||||||
import { WebdavConfig, DEFAULT_WEBDAV_CONFIG, WebdavAuthType } from "./webdav";
|
import { DEFAULT_S3_CONFIG } from "./remoteForS3";
|
||||||
|
import { DEFAULT_WEBDAV_CONFIG } from "./remoteForWebdav";
|
||||||
|
import {
|
||||||
|
DEFAULT_DROPBOX_CONFIG,
|
||||||
|
getAuthUrlAndVerifier,
|
||||||
|
sendAuthReq,
|
||||||
|
setConfigBySuccessfullAuthInplace,
|
||||||
|
} from "./remoteForDropbox";
|
||||||
|
|
||||||
import { RemoteClient } from "./remote";
|
import { RemoteClient } from "./remote";
|
||||||
import { exportSyncPlansToFiles } from "./debugMode";
|
import { exportSyncPlansToFiles } from "./debugMode";
|
||||||
import { SUPPORTED_SERVICES_TYPE } from "./baseTypes";
|
import { COMMAND_URI, COMMAND_CALLBACK } from "./baseTypes";
|
||||||
|
import type {
|
||||||
interface RemotelySavePluginSettings {
|
SUPPORTED_SERVICES_TYPE,
|
||||||
s3: S3Config;
|
S3Config,
|
||||||
webdav: WebdavConfig;
|
DropboxConfig,
|
||||||
password: string;
|
WebdavAuthType,
|
||||||
serviceType: SUPPORTED_SERVICES_TYPE;
|
WebdavConfig,
|
||||||
enableExperimentService: boolean;
|
RemotelySavePluginSettings,
|
||||||
}
|
} from "./baseTypes";
|
||||||
|
import type { ProcessQrCodeResultType } from "./importExport";
|
||||||
|
import { exportQrCodeUri, importQrCodeUri } from "./importExport";
|
||||||
|
|
||||||
const DEFAULT_SETTINGS: RemotelySavePluginSettings = {
|
const DEFAULT_SETTINGS: RemotelySavePluginSettings = {
|
||||||
s3: DEFAULT_S3_CONFIG,
|
s3: DEFAULT_S3_CONFIG,
|
||||||
webdav: DEFAULT_WEBDAV_CONFIG,
|
webdav: DEFAULT_WEBDAV_CONFIG,
|
||||||
|
dropbox: DEFAULT_DROPBOX_CONFIG,
|
||||||
password: "",
|
password: "",
|
||||||
serviceType: "s3",
|
serviceType: "s3",
|
||||||
enableExperimentService: false,
|
|
||||||
};
|
};
|
||||||
|
|
||||||
export default class RemotelySavePlugin extends Plugin {
|
export default class RemotelySavePlugin extends Plugin {
|
||||||
@@ -54,7 +65,7 @@ export default class RemotelySavePlugin extends Plugin {
|
|||||||
syncStatus: SyncStatusType;
|
syncStatus: SyncStatusType;
|
||||||
|
|
||||||
async onload() {
|
async onload() {
|
||||||
console.log("loading plugin obsidian-remotely-save");
|
console.log("loading plugin remotely-save");
|
||||||
|
|
||||||
await this.loadSettings();
|
await this.loadSettings();
|
||||||
|
|
||||||
@@ -74,6 +85,32 @@ export default class RemotelySavePlugin extends Plugin {
|
|||||||
})
|
})
|
||||||
);
|
);
|
||||||
|
|
||||||
|
this.registerObsidianProtocolHandler(COMMAND_URI, async (inputParams) => {
|
||||||
|
const parsed = importQrCodeUri(inputParams, this.app.vault.getName());
|
||||||
|
if (parsed.status === "error") {
|
||||||
|
new Notice(parsed.message);
|
||||||
|
} else {
|
||||||
|
const copied = JSON.parse(JSON.stringify(parsed.result));
|
||||||
|
// new Notice(JSON.stringify(copied))
|
||||||
|
this.settings = copied;
|
||||||
|
this.saveSettings();
|
||||||
|
new Notice(
|
||||||
|
`New settings for ${this.manifest.name} saved. Reopen the plugin Settings to the effect.`
|
||||||
|
);
|
||||||
|
}
|
||||||
|
});
|
||||||
|
|
||||||
|
this.registerObsidianProtocolHandler(
|
||||||
|
COMMAND_CALLBACK,
|
||||||
|
async (inputParams) => {
|
||||||
|
new Notice(
|
||||||
|
`Your uri call a callback that's not supported yet: ${JSON.stringify(
|
||||||
|
inputParams
|
||||||
|
)}`
|
||||||
|
);
|
||||||
|
}
|
||||||
|
);
|
||||||
|
|
||||||
this.addRibbonIcon("switch", "Remotely Save", async () => {
|
this.addRibbonIcon("switch", "Remotely Save", async () => {
|
||||||
if (this.syncStatus !== "idle") {
|
if (this.syncStatus !== "idle") {
|
||||||
new Notice(
|
new Notice(
|
||||||
@@ -91,18 +128,22 @@ export default class RemotelySavePlugin extends Plugin {
|
|||||||
|
|
||||||
new Notice("2/6 Starting to fetch remote meta data.");
|
new Notice("2/6 Starting to fetch remote meta data.");
|
||||||
this.syncStatus = "getting_remote_meta";
|
this.syncStatus = "getting_remote_meta";
|
||||||
|
const self = this;
|
||||||
const client = new RemoteClient(
|
const client = new RemoteClient(
|
||||||
this.settings.serviceType,
|
this.settings.serviceType,
|
||||||
this.settings.s3,
|
this.settings.s3,
|
||||||
this.settings.webdav
|
this.settings.webdav,
|
||||||
|
this.settings.dropbox,
|
||||||
|
this.app.vault.getName(),
|
||||||
|
() => self.saveSettings()
|
||||||
);
|
);
|
||||||
const remoteRsp = await client.listFromRemote();
|
const remoteRsp = await client.listFromRemote();
|
||||||
|
// console.log(remoteRsp);
|
||||||
|
|
||||||
new Notice("3/6 Starting to fetch local meta data.");
|
new Notice("3/6 Starting to fetch local meta data.");
|
||||||
this.syncStatus = "getting_local_meta";
|
this.syncStatus = "getting_local_meta";
|
||||||
const local = this.app.vault.getAllLoadedFiles();
|
const local = this.app.vault.getAllLoadedFiles();
|
||||||
const localHistory = await loadDeleteRenameHistoryTable(this.db);
|
const localHistory = await loadDeleteRenameHistoryTable(this.db);
|
||||||
// console.log(remoteRsp);
|
|
||||||
// console.log(local);
|
// console.log(local);
|
||||||
// console.log(localHistory);
|
// console.log(localHistory);
|
||||||
|
|
||||||
@@ -174,12 +215,19 @@ export default class RemotelySavePlugin extends Plugin {
|
|||||||
}
|
}
|
||||||
|
|
||||||
onunload() {
|
onunload() {
|
||||||
console.log("unloading plugin obsidian-remotely-save");
|
console.log("unloading plugin remotely-save");
|
||||||
this.destroyDBs();
|
this.destroyDBs();
|
||||||
}
|
}
|
||||||
|
|
||||||
async loadSettings() {
|
async loadSettings() {
|
||||||
this.settings = Object.assign({}, DEFAULT_SETTINGS, await this.loadData());
|
this.settings = Object.assign(
|
||||||
|
{},
|
||||||
|
JSON.parse(JSON.stringify(DEFAULT_SETTINGS)) /* copy an object */,
|
||||||
|
await this.loadData()
|
||||||
|
);
|
||||||
|
if (this.settings.dropbox.clientID === "") {
|
||||||
|
this.settings.dropbox.clientID = DEFAULT_SETTINGS.dropbox.clientID;
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
async saveSettings() {
|
async saveSettings() {
|
||||||
@@ -253,6 +301,164 @@ export class PasswordModal extends Modal {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
export class DropboxAuthModal extends Modal {
|
||||||
|
readonly plugin: RemotelySavePlugin;
|
||||||
|
readonly authDiv: HTMLDivElement;
|
||||||
|
readonly revokeAuthDiv: HTMLDivElement;
|
||||||
|
readonly revokeAuthSetting: Setting;
|
||||||
|
constructor(
|
||||||
|
app: App,
|
||||||
|
plugin: RemotelySavePlugin,
|
||||||
|
authDiv: HTMLDivElement,
|
||||||
|
revokeAuthDiv: HTMLDivElement,
|
||||||
|
revokeAuthSetting: Setting
|
||||||
|
) {
|
||||||
|
super(app);
|
||||||
|
this.plugin = plugin;
|
||||||
|
this.authDiv = authDiv;
|
||||||
|
this.revokeAuthDiv = revokeAuthDiv;
|
||||||
|
this.revokeAuthSetting = revokeAuthSetting;
|
||||||
|
}
|
||||||
|
|
||||||
|
async onOpen() {
|
||||||
|
let { contentEl } = this;
|
||||||
|
|
||||||
|
const { authUrl, verifier } = await getAuthUrlAndVerifier(
|
||||||
|
this.plugin.settings.dropbox.clientID
|
||||||
|
);
|
||||||
|
|
||||||
|
contentEl.createEl("p", {
|
||||||
|
text: "Step 1: Visit the following address in a browser, and follow the steps on the web page to authorize.",
|
||||||
|
});
|
||||||
|
contentEl.createEl("p").createEl("a", {
|
||||||
|
href: authUrl,
|
||||||
|
text: authUrl,
|
||||||
|
});
|
||||||
|
|
||||||
|
contentEl.createEl("p", {
|
||||||
|
text: 'Step 2: In the end of the web flow, you obtain a long code. Paste it here then click "Submit".',
|
||||||
|
});
|
||||||
|
|
||||||
|
let authCode = "";
|
||||||
|
new Setting(contentEl)
|
||||||
|
.setName("Auth Code from web page")
|
||||||
|
.setDesc('You need to click "Confirm".')
|
||||||
|
.addText((text) =>
|
||||||
|
text
|
||||||
|
.setPlaceholder("")
|
||||||
|
.setValue("")
|
||||||
|
.onChange((val) => {
|
||||||
|
authCode = val.trim();
|
||||||
|
})
|
||||||
|
)
|
||||||
|
.addButton(async (button) => {
|
||||||
|
button.setButtonText("Confirm");
|
||||||
|
button.onClick(async () => {
|
||||||
|
new Notice("Trying to connect to Dropbox");
|
||||||
|
try {
|
||||||
|
const authRes = await sendAuthReq(
|
||||||
|
this.plugin.settings.dropbox.clientID,
|
||||||
|
verifier,
|
||||||
|
authCode
|
||||||
|
);
|
||||||
|
const self = this;
|
||||||
|
setConfigBySuccessfullAuthInplace(
|
||||||
|
this.plugin.settings.dropbox,
|
||||||
|
authRes,
|
||||||
|
() => self.plugin.saveSettings()
|
||||||
|
);
|
||||||
|
const client = new RemoteClient(
|
||||||
|
"dropbox",
|
||||||
|
undefined,
|
||||||
|
undefined,
|
||||||
|
this.plugin.settings.dropbox,
|
||||||
|
this.app.vault.getName(),
|
||||||
|
() => self.plugin.saveSettings()
|
||||||
|
);
|
||||||
|
const username = await client.getUser();
|
||||||
|
this.plugin.settings.dropbox.username = username;
|
||||||
|
await this.plugin.saveSettings();
|
||||||
|
new Notice(`Good! We've connected to Dropbox as user ${username}!`);
|
||||||
|
this.authDiv.toggleClass(
|
||||||
|
"dropbox-auth-button-hide",
|
||||||
|
this.plugin.settings.dropbox.username !== ""
|
||||||
|
);
|
||||||
|
this.revokeAuthDiv.toggleClass(
|
||||||
|
"dropbox-revoke-auth-button-hide",
|
||||||
|
this.plugin.settings.dropbox.username === ""
|
||||||
|
);
|
||||||
|
this.revokeAuthSetting.setDesc(
|
||||||
|
`You've connected as user ${this.plugin.settings.dropbox.username}. If you want to disconnect, click this button`
|
||||||
|
);
|
||||||
|
this.close();
|
||||||
|
} catch (err) {
|
||||||
|
console.error(err);
|
||||||
|
new Notice("Something goes wrong while connecting to Dropbox.");
|
||||||
|
}
|
||||||
|
});
|
||||||
|
});
|
||||||
|
}
|
||||||
|
|
||||||
|
onClose() {
|
||||||
|
let { contentEl } = this;
|
||||||
|
contentEl.empty();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
export class ExportSettingsQrCodeModal extends Modal {
|
||||||
|
plugin: RemotelySavePlugin;
|
||||||
|
constructor(app: App, plugin: RemotelySavePlugin) {
|
||||||
|
super(app);
|
||||||
|
this.plugin = plugin;
|
||||||
|
}
|
||||||
|
|
||||||
|
async onOpen() {
|
||||||
|
let { contentEl } = this;
|
||||||
|
|
||||||
|
const { rawUri, imgUri } = await exportQrCodeUri(
|
||||||
|
this.plugin.settings,
|
||||||
|
this.app.vault.getName(),
|
||||||
|
this.plugin.manifest.version
|
||||||
|
);
|
||||||
|
|
||||||
|
contentEl.createEl("p", {
|
||||||
|
text: "You can use another device to scan this qrcode.",
|
||||||
|
});
|
||||||
|
|
||||||
|
contentEl.createEl("p", {
|
||||||
|
text: "Or, you can click the button to copy the special url.",
|
||||||
|
});
|
||||||
|
|
||||||
|
contentEl.createEl(
|
||||||
|
"button",
|
||||||
|
{
|
||||||
|
text: "Click to copy the special URI",
|
||||||
|
},
|
||||||
|
(el) => {
|
||||||
|
el.onclick = async () => {
|
||||||
|
await navigator.clipboard.writeText(rawUri);
|
||||||
|
new Notice("special uri copied to clipboard!");
|
||||||
|
};
|
||||||
|
}
|
||||||
|
);
|
||||||
|
|
||||||
|
contentEl.createEl(
|
||||||
|
"img",
|
||||||
|
{
|
||||||
|
cls: "qrcode-img",
|
||||||
|
},
|
||||||
|
async (el) => {
|
||||||
|
el.src = imgUri;
|
||||||
|
}
|
||||||
|
);
|
||||||
|
}
|
||||||
|
|
||||||
|
onClose() {
|
||||||
|
let { contentEl } = this;
|
||||||
|
contentEl.empty();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
class RemotelySaveSettingTab extends PluginSettingTab {
|
class RemotelySaveSettingTab extends PluginSettingTab {
|
||||||
plugin: RemotelySavePlugin;
|
plugin: RemotelySavePlugin;
|
||||||
|
|
||||||
@@ -293,45 +499,12 @@ class RemotelySaveSettingTab extends PluginSettingTab {
|
|||||||
});
|
});
|
||||||
});
|
});
|
||||||
|
|
||||||
// we need to create the div in advance of s3Div and webdavDiv
|
// we need to create the div in advance of any other service divs
|
||||||
const serviceChooserDiv = generalDiv.createEl("div");
|
const serviceChooserDiv = generalDiv.createEl("div");
|
||||||
|
|
||||||
let clickChooserTimes = 0;
|
|
||||||
serviceChooserDiv.onClickEvent((x) => {
|
|
||||||
if (Platform.isIosApp) {
|
|
||||||
// downgrade the experiment
|
|
||||||
// because iOS doesn't support x.detail
|
|
||||||
clickChooserTimes += 1;
|
|
||||||
setTimeout(function () {
|
|
||||||
clickChooserTimes = 0;
|
|
||||||
}, 2000);
|
|
||||||
}
|
|
||||||
|
|
||||||
if ((Platform.isIosApp && clickChooserTimes === 5) || x.detail === 5) {
|
|
||||||
if (this.plugin.settings.serviceType === "webdav") {
|
|
||||||
new Notice(
|
|
||||||
"You've enabled hidden unstable experimental webdav support before. Nothing changes."
|
|
||||||
);
|
|
||||||
} else if (!this.plugin.settings.enableExperimentService) {
|
|
||||||
this.plugin.settings.enableExperimentService = true;
|
|
||||||
this.plugin.saveSettings();
|
|
||||||
new Notice(
|
|
||||||
"You've enabled hidden unstable experimental webdav support. Reopen settings again and try webdav with caution."
|
|
||||||
);
|
|
||||||
} else if (this.plugin.settings.enableExperimentService) {
|
|
||||||
this.plugin.settings.enableExperimentService = false;
|
|
||||||
this.plugin.saveSettings();
|
|
||||||
new Notice(
|
|
||||||
"You've disabled hidden unstable experimental webdav support. Reopen settings again."
|
|
||||||
);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
x.preventDefault();
|
|
||||||
});
|
|
||||||
|
|
||||||
const s3Div = containerEl.createEl("div", { cls: "s3-hide" });
|
const s3Div = containerEl.createEl("div", { cls: "s3-hide" });
|
||||||
s3Div.toggleClass("s3-hide", this.plugin.settings.serviceType !== "s3");
|
s3Div.toggleClass("s3-hide", this.plugin.settings.serviceType !== "s3");
|
||||||
s3Div.createEl("h2", { text: "S3 (-compatible) Service" });
|
s3Div.createEl("h2", { text: "Remote For S3 (-compatible)" });
|
||||||
|
|
||||||
s3Div.createEl("p", {
|
s3Div.createEl("p", {
|
||||||
text: "You can use Amazon S3 or another S3-compatible service to sync your vault. Enter your bucket information below.",
|
text: "You can use Amazon S3 or another S3-compatible service to sync your vault. Enter your bucket information below.",
|
||||||
@@ -453,13 +626,133 @@ class RemotelySaveSettingTab extends PluginSettingTab {
|
|||||||
});
|
});
|
||||||
});
|
});
|
||||||
|
|
||||||
|
const dropboxDiv = containerEl.createEl("div", { cls: "dropbox-hide" });
|
||||||
|
dropboxDiv.toggleClass(
|
||||||
|
"dropbox-hide",
|
||||||
|
this.plugin.settings.serviceType !== "dropbox"
|
||||||
|
);
|
||||||
|
dropboxDiv.createEl("h2", { text: "Remote For Dropbox" });
|
||||||
|
dropboxDiv.createEl("p", {
|
||||||
|
text: "Disclaimer: Sync support for Dropbox are more experimental, and s3 functions are more stable now.",
|
||||||
|
cls: "dropbox-disclaimer",
|
||||||
|
});
|
||||||
|
dropboxDiv.createEl("p", {
|
||||||
|
text: "Disclaimer: This app is NOT an official Dropbox product. It just uses Dropbox open api.",
|
||||||
|
cls: "dropbox-disclaimer",
|
||||||
|
});
|
||||||
|
dropboxDiv.createEl("p", {
|
||||||
|
text: "Disclaimer: The infomation is stored in PLAIN TEXT locally. Other malicious/harmful/faulty plugins may or may not be able to read the info. If you see any unintentional access to your Dropbox, please immediately disconnect this app on https://www.dropbox.com/account/connected_apps .",
|
||||||
|
cls: "dropbox-disclaimer",
|
||||||
|
});
|
||||||
|
dropboxDiv.createEl("p", {
|
||||||
|
text: "We will create a folder Apps/remotely-save on your Dropbox. All files/folders sync would happen inside this folder.",
|
||||||
|
});
|
||||||
|
|
||||||
|
const dropboxSelectAuthDiv = dropboxDiv.createDiv();
|
||||||
|
const dropboxAuthDiv = dropboxSelectAuthDiv.createDiv({
|
||||||
|
cls: "dropbox-auth-button-hide",
|
||||||
|
});
|
||||||
|
const dropboxRevokeAuthDiv = dropboxSelectAuthDiv.createDiv({
|
||||||
|
cls: "dropbox-revoke-auth-button-hide",
|
||||||
|
});
|
||||||
|
|
||||||
|
const revokeAuthSetting = new Setting(dropboxRevokeAuthDiv)
|
||||||
|
.setName("Revoke Auth")
|
||||||
|
.setDesc(
|
||||||
|
`You've connected as user ${this.plugin.settings.dropbox.username}. If you want to disconnect, click this button`
|
||||||
|
)
|
||||||
|
.addButton(async (button) => {
|
||||||
|
button.setButtonText("Revoke Auth");
|
||||||
|
button.onClick(async () => {
|
||||||
|
try {
|
||||||
|
const self = this;
|
||||||
|
const client = new RemoteClient(
|
||||||
|
"dropbox",
|
||||||
|
undefined,
|
||||||
|
undefined,
|
||||||
|
this.plugin.settings.dropbox,
|
||||||
|
this.app.vault.getName(),
|
||||||
|
() => self.plugin.saveSettings()
|
||||||
|
);
|
||||||
|
await client.revokeAuth();
|
||||||
|
this.plugin.settings.dropbox = JSON.parse(
|
||||||
|
JSON.stringify(DEFAULT_DROPBOX_CONFIG)
|
||||||
|
);
|
||||||
|
await this.plugin.saveSettings();
|
||||||
|
dropboxAuthDiv.toggleClass(
|
||||||
|
"dropbox-auth-button-hide",
|
||||||
|
this.plugin.settings.dropbox.username !== ""
|
||||||
|
);
|
||||||
|
dropboxRevokeAuthDiv.toggleClass(
|
||||||
|
"dropbox-revoke-auth-button-hide",
|
||||||
|
this.plugin.settings.dropbox.username === ""
|
||||||
|
);
|
||||||
|
new Notice("Revoked!");
|
||||||
|
} catch (err) {
|
||||||
|
console.error(err);
|
||||||
|
new Notice("Something goes wrong while revoking");
|
||||||
|
}
|
||||||
|
});
|
||||||
|
});
|
||||||
|
|
||||||
|
new Setting(dropboxAuthDiv)
|
||||||
|
.setName("Auth")
|
||||||
|
.setDesc("Auth")
|
||||||
|
.addButton(async (button) => {
|
||||||
|
button.setButtonText("Auth");
|
||||||
|
button.onClick(async () => {
|
||||||
|
new DropboxAuthModal(
|
||||||
|
this.app,
|
||||||
|
this.plugin,
|
||||||
|
dropboxAuthDiv,
|
||||||
|
dropboxRevokeAuthDiv,
|
||||||
|
revokeAuthSetting
|
||||||
|
).open();
|
||||||
|
});
|
||||||
|
});
|
||||||
|
|
||||||
|
dropboxAuthDiv.toggleClass(
|
||||||
|
"dropbox-auth-button-hide",
|
||||||
|
this.plugin.settings.dropbox.username !== ""
|
||||||
|
);
|
||||||
|
dropboxRevokeAuthDiv.toggleClass(
|
||||||
|
"dropbox-revoke-auth-button-hide",
|
||||||
|
this.plugin.settings.dropbox.username === ""
|
||||||
|
);
|
||||||
|
|
||||||
|
new Setting(dropboxDiv)
|
||||||
|
.setName("check connectivity")
|
||||||
|
.setDesc("check connectivity")
|
||||||
|
.addButton(async (button) => {
|
||||||
|
button.setButtonText("Check");
|
||||||
|
button.onClick(async () => {
|
||||||
|
new Notice("Checking...");
|
||||||
|
const self = this;
|
||||||
|
const client = new RemoteClient(
|
||||||
|
"dropbox",
|
||||||
|
undefined,
|
||||||
|
undefined,
|
||||||
|
this.plugin.settings.dropbox,
|
||||||
|
this.app.vault.getName(),
|
||||||
|
() => self.plugin.saveSettings()
|
||||||
|
);
|
||||||
|
|
||||||
|
const res = await client.checkConnectivity();
|
||||||
|
if (res) {
|
||||||
|
new Notice("Great! We can connect to Dropbox!");
|
||||||
|
} else {
|
||||||
|
new Notice("We cannot connect to Dropbox.");
|
||||||
|
}
|
||||||
|
});
|
||||||
|
});
|
||||||
|
|
||||||
const webdavDiv = containerEl.createEl("div", { cls: "webdav-hide" });
|
const webdavDiv = containerEl.createEl("div", { cls: "webdav-hide" });
|
||||||
webdavDiv.toggleClass(
|
webdavDiv.toggleClass(
|
||||||
"webdav-hide",
|
"webdav-hide",
|
||||||
this.plugin.settings.serviceType !== "webdav"
|
this.plugin.settings.serviceType !== "webdav"
|
||||||
);
|
);
|
||||||
|
|
||||||
webdavDiv.createEl("h2", { text: "Webdav Service" });
|
webdavDiv.createEl("h2", { text: "Remote For Webdav" });
|
||||||
|
|
||||||
webdavDiv.createEl("p", {
|
webdavDiv.createEl("p", {
|
||||||
text: "Disclaimer: Webdav functions are more experimental, and s3 functions are more stable now.",
|
text: "Disclaimer: Webdav functions are more experimental, and s3 functions are more stable now.",
|
||||||
@@ -521,7 +814,7 @@ class RemotelySaveSettingTab extends PluginSettingTab {
|
|||||||
)
|
)
|
||||||
.addDropdown((dropdown) => {
|
.addDropdown((dropdown) => {
|
||||||
dropdown.addOption("basic", "basic");
|
dropdown.addOption("basic", "basic");
|
||||||
dropdown.addOption("digest", "digest");
|
// dropdown.addOption("digest", "digest");
|
||||||
|
|
||||||
dropdown
|
dropdown
|
||||||
.setValue(this.plugin.settings.webdav.authType)
|
.setValue(this.plugin.settings.webdav.authType)
|
||||||
@@ -559,17 +852,10 @@ class RemotelySaveSettingTab extends PluginSettingTab {
|
|||||||
.setDesc("Choose a service, by default s3")
|
.setDesc("Choose a service, by default s3")
|
||||||
.addDropdown(async (dropdown) => {
|
.addDropdown(async (dropdown) => {
|
||||||
const currService = this.plugin.settings.serviceType;
|
const currService = this.plugin.settings.serviceType;
|
||||||
const enableExperimentService =
|
|
||||||
this.plugin.settings.enableExperimentService;
|
|
||||||
|
|
||||||
dropdown.addOption("s3", "s3 (-compatible)");
|
dropdown.addOption("s3", "s3 (-compatible)");
|
||||||
if (currService === "webdav" || enableExperimentService) {
|
dropdown.addOption("dropbox", "Dropbox");
|
||||||
dropdown.addOption("webdav", "webdav (experimental)");
|
dropdown.addOption("webdav", "webdav (experimental)");
|
||||||
if (!enableExperimentService) {
|
|
||||||
this.plugin.settings.enableExperimentService = true;
|
|
||||||
await this.plugin.saveSettings();
|
|
||||||
}
|
|
||||||
}
|
|
||||||
dropdown
|
dropdown
|
||||||
.setValue(this.plugin.settings.serviceType)
|
.setValue(this.plugin.settings.serviceType)
|
||||||
.onChange(async (val: SUPPORTED_SERVICES_TYPE) => {
|
.onChange(async (val: SUPPORTED_SERVICES_TYPE) => {
|
||||||
@@ -578,6 +864,10 @@ class RemotelySaveSettingTab extends PluginSettingTab {
|
|||||||
"s3-hide",
|
"s3-hide",
|
||||||
this.plugin.settings.serviceType !== "s3"
|
this.plugin.settings.serviceType !== "s3"
|
||||||
);
|
);
|
||||||
|
dropboxDiv.toggleClass(
|
||||||
|
"dropbox-hide",
|
||||||
|
this.plugin.settings.serviceType !== "dropbox"
|
||||||
|
);
|
||||||
webdavDiv.toggleClass(
|
webdavDiv.toggleClass(
|
||||||
"webdav-hide",
|
"webdav-hide",
|
||||||
this.plugin.settings.serviceType !== "webdav"
|
this.plugin.settings.serviceType !== "webdav"
|
||||||
@@ -586,6 +876,24 @@ class RemotelySaveSettingTab extends PluginSettingTab {
|
|||||||
});
|
});
|
||||||
});
|
});
|
||||||
|
|
||||||
|
// import and export
|
||||||
|
const importExportDiv = containerEl.createEl("div");
|
||||||
|
importExportDiv.createEl("h2", { text: "Import and Export Settings" });
|
||||||
|
|
||||||
|
new Setting(importExportDiv)
|
||||||
|
.setName("export")
|
||||||
|
.setDesc("export all settings by generating qrcode")
|
||||||
|
.addButton(async (button) => {
|
||||||
|
button.setButtonText("Get QR Code");
|
||||||
|
button.onClick(async () => {
|
||||||
|
new ExportSettingsQrCodeModal(this.app, this.plugin).open();
|
||||||
|
});
|
||||||
|
});
|
||||||
|
|
||||||
|
new Setting(importExportDiv)
|
||||||
|
.setName("import")
|
||||||
|
.setDesc("You should manually open a camera app to scan the QR code");
|
||||||
|
|
||||||
const debugDiv = containerEl.createEl("div");
|
const debugDiv = containerEl.createEl("div");
|
||||||
debugDiv.createEl("h2", { text: "Debug" });
|
debugDiv.createEl("h2", { text: "Debug" });
|
||||||
const syncPlanDiv = debugDiv.createEl("div");
|
const syncPlanDiv = debugDiv.createEl("div");
|
||||||
|
|||||||
+14
-1
@@ -45,7 +45,10 @@ export const getFolderLevels = (x: string) => {
|
|||||||
const y1 = x.split("/");
|
const y1 = x.split("/");
|
||||||
let i = 0;
|
let i = 0;
|
||||||
for (let index = 0; index + 1 < y1.length; index++) {
|
for (let index = 0; index + 1 < y1.length; index++) {
|
||||||
res.push(y1.slice(0, index + 1).join("/"));
|
const k = y1.slice(0, index + 1).join("/");
|
||||||
|
if (k !== "" && k !== "/") {
|
||||||
|
res.push(k);
|
||||||
|
}
|
||||||
}
|
}
|
||||||
return res;
|
return res;
|
||||||
};
|
};
|
||||||
@@ -142,3 +145,13 @@ export const getPathFolder = (a: string) => {
|
|||||||
const b = path.posix.dirname(a);
|
const b = path.posix.dirname(a);
|
||||||
return b.endsWith("/") ? b : `${b}/`;
|
return b.endsWith("/") ? b : `${b}/`;
|
||||||
};
|
};
|
||||||
|
|
||||||
|
/**
|
||||||
|
* https://stackoverflow.com/questions/54511144
|
||||||
|
* @param a
|
||||||
|
* @param delimiter
|
||||||
|
* @returns
|
||||||
|
*/
|
||||||
|
export const setToString = (a: Set<string>, delimiter: string = ",") => {
|
||||||
|
return [...a].join(delimiter);
|
||||||
|
};
|
||||||
|
|||||||
+84
-10
@@ -1,28 +1,53 @@
|
|||||||
import { Vault } from "obsidian";
|
import { Vault } from "obsidian";
|
||||||
|
|
||||||
import type { SUPPORTED_SERVICES_TYPE } from "./baseTypes";
|
import type {
|
||||||
import * as s3 from "./s3";
|
SUPPORTED_SERVICES_TYPE,
|
||||||
import * as webdav from "./webdav";
|
S3Config,
|
||||||
|
DropboxConfig,
|
||||||
|
WebdavConfig,
|
||||||
|
} from "./baseTypes";
|
||||||
|
import * as s3 from "./remoteForS3";
|
||||||
|
import * as webdav from "./remoteForWebdav";
|
||||||
|
import * as dropbox from "./remoteForDropbox";
|
||||||
|
|
||||||
export class RemoteClient {
|
export class RemoteClient {
|
||||||
readonly serviceType: SUPPORTED_SERVICES_TYPE;
|
readonly serviceType: SUPPORTED_SERVICES_TYPE;
|
||||||
readonly s3Client?: s3.S3Client;
|
readonly s3Client?: s3.S3Client;
|
||||||
readonly s3Config?: s3.S3Config;
|
readonly s3Config?: S3Config;
|
||||||
readonly webdavClient?: webdav.WebDAVClient;
|
readonly webdavClient?: webdav.WebDAVClient;
|
||||||
readonly webdavConfig?: webdav.WebdavConfig;
|
readonly webdavConfig?: WebdavConfig;
|
||||||
|
readonly dropboxClient?: dropbox.WrappedDropboxClient;
|
||||||
|
readonly dropboxConfig?: DropboxConfig;
|
||||||
|
|
||||||
constructor(
|
constructor(
|
||||||
serviceType: SUPPORTED_SERVICES_TYPE,
|
serviceType: SUPPORTED_SERVICES_TYPE,
|
||||||
s3Config?: s3.S3Config,
|
s3Config?: S3Config,
|
||||||
webdavConfig?: webdav.WebdavConfig
|
webdavConfig?: WebdavConfig,
|
||||||
|
dropboxConfig?: DropboxConfig,
|
||||||
|
vaultName?: string,
|
||||||
|
saveUpdatedConfigFunc?: () => Promise<any>
|
||||||
) {
|
) {
|
||||||
this.serviceType = serviceType;
|
this.serviceType = serviceType;
|
||||||
|
// the client may modify the config inplace,
|
||||||
|
// so we use a ref not copy of config here
|
||||||
if (serviceType === "s3") {
|
if (serviceType === "s3") {
|
||||||
this.s3Config = s3Config;
|
this.s3Config = s3Config;
|
||||||
this.s3Client = s3.getS3Client(s3Config);
|
this.s3Client = s3.getS3Client(this.s3Config);
|
||||||
} else if (serviceType === "webdav") {
|
} else if (serviceType === "webdav") {
|
||||||
this.webdavConfig = webdavConfig;
|
this.webdavConfig = webdavConfig;
|
||||||
this.webdavClient = webdav.getWebdavClient(webdavConfig);
|
this.webdavClient = webdav.getWebdavClient(this.webdavConfig);
|
||||||
|
} else if (serviceType === "dropbox") {
|
||||||
|
if (vaultName === undefined || saveUpdatedConfigFunc === undefined) {
|
||||||
|
throw Error(
|
||||||
|
"remember to provide vault name and callback while init dropbox client"
|
||||||
|
);
|
||||||
|
}
|
||||||
|
this.dropboxConfig = dropboxConfig;
|
||||||
|
this.dropboxClient = dropbox.getDropboxClient(
|
||||||
|
this.dropboxConfig,
|
||||||
|
vaultName,
|
||||||
|
saveUpdatedConfigFunc
|
||||||
|
);
|
||||||
} else {
|
} else {
|
||||||
throw Error(`not supported service type ${this.serviceType}`);
|
throw Error(`not supported service type ${this.serviceType}`);
|
||||||
}
|
}
|
||||||
@@ -37,6 +62,8 @@ export class RemoteClient {
|
|||||||
);
|
);
|
||||||
} else if (this.serviceType === "webdav") {
|
} else if (this.serviceType === "webdav") {
|
||||||
return await webdav.getRemoteMeta(this.webdavClient, fileOrFolderPath);
|
return await webdav.getRemoteMeta(this.webdavClient, fileOrFolderPath);
|
||||||
|
} else if (this.serviceType === "dropbox") {
|
||||||
|
return await dropbox.getRemoteMeta(this.dropboxClient, fileOrFolderPath);
|
||||||
} else {
|
} else {
|
||||||
throw Error(`not supported service type ${this.serviceType}`);
|
throw Error(`not supported service type ${this.serviceType}`);
|
||||||
}
|
}
|
||||||
@@ -47,7 +74,8 @@ export class RemoteClient {
|
|||||||
vault: Vault,
|
vault: Vault,
|
||||||
isRecursively: boolean = false,
|
isRecursively: boolean = false,
|
||||||
password: string = "",
|
password: string = "",
|
||||||
remoteEncryptedKey: string = ""
|
remoteEncryptedKey: string = "",
|
||||||
|
foldersCreatedBefore: Set<string> | undefined = undefined
|
||||||
) => {
|
) => {
|
||||||
if (this.serviceType === "s3") {
|
if (this.serviceType === "s3") {
|
||||||
return await s3.uploadToRemote(
|
return await s3.uploadToRemote(
|
||||||
@@ -68,6 +96,16 @@ export class RemoteClient {
|
|||||||
password,
|
password,
|
||||||
remoteEncryptedKey
|
remoteEncryptedKey
|
||||||
);
|
);
|
||||||
|
} else if (this.serviceType === "dropbox") {
|
||||||
|
return await dropbox.uploadToRemote(
|
||||||
|
this.dropboxClient,
|
||||||
|
fileOrFolderPath,
|
||||||
|
vault,
|
||||||
|
isRecursively,
|
||||||
|
password,
|
||||||
|
remoteEncryptedKey,
|
||||||
|
foldersCreatedBefore
|
||||||
|
);
|
||||||
} else {
|
} else {
|
||||||
throw Error(`not supported service type ${this.serviceType}`);
|
throw Error(`not supported service type ${this.serviceType}`);
|
||||||
}
|
}
|
||||||
@@ -78,6 +116,8 @@ export class RemoteClient {
|
|||||||
return await s3.listFromRemote(this.s3Client, this.s3Config, prefix);
|
return await s3.listFromRemote(this.s3Client, this.s3Config, prefix);
|
||||||
} else if (this.serviceType === "webdav") {
|
} else if (this.serviceType === "webdav") {
|
||||||
return await webdav.listFromRemote(this.webdavClient, prefix);
|
return await webdav.listFromRemote(this.webdavClient, prefix);
|
||||||
|
} else if (this.serviceType === "dropbox") {
|
||||||
|
return await dropbox.listFromRemote(this.dropboxClient, prefix);
|
||||||
} else {
|
} else {
|
||||||
throw Error(`not supported service type ${this.serviceType}`);
|
throw Error(`not supported service type ${this.serviceType}`);
|
||||||
}
|
}
|
||||||
@@ -109,6 +149,15 @@ export class RemoteClient {
|
|||||||
password,
|
password,
|
||||||
remoteEncryptedKey
|
remoteEncryptedKey
|
||||||
);
|
);
|
||||||
|
} else if (this.serviceType === "dropbox") {
|
||||||
|
return await dropbox.downloadFromRemote(
|
||||||
|
this.dropboxClient,
|
||||||
|
fileOrFolderPath,
|
||||||
|
vault,
|
||||||
|
mtime,
|
||||||
|
password,
|
||||||
|
remoteEncryptedKey
|
||||||
|
);
|
||||||
} else {
|
} else {
|
||||||
throw Error(`not supported service type ${this.serviceType}`);
|
throw Error(`not supported service type ${this.serviceType}`);
|
||||||
}
|
}
|
||||||
@@ -134,6 +183,13 @@ export class RemoteClient {
|
|||||||
password,
|
password,
|
||||||
remoteEncryptedKey
|
remoteEncryptedKey
|
||||||
);
|
);
|
||||||
|
} else if (this.serviceType === "dropbox") {
|
||||||
|
return await dropbox.deleteFromRemote(
|
||||||
|
this.dropboxClient,
|
||||||
|
fileOrFolderPath,
|
||||||
|
password,
|
||||||
|
remoteEncryptedKey
|
||||||
|
);
|
||||||
} else {
|
} else {
|
||||||
throw Error(`not supported service type ${this.serviceType}`);
|
throw Error(`not supported service type ${this.serviceType}`);
|
||||||
}
|
}
|
||||||
@@ -144,6 +200,24 @@ export class RemoteClient {
|
|||||||
return await s3.checkConnectivity(this.s3Client, this.s3Config);
|
return await s3.checkConnectivity(this.s3Client, this.s3Config);
|
||||||
} else if (this.serviceType === "webdav") {
|
} else if (this.serviceType === "webdav") {
|
||||||
return await webdav.checkConnectivity(this.webdavClient);
|
return await webdav.checkConnectivity(this.webdavClient);
|
||||||
|
} else if (this.serviceType === "dropbox") {
|
||||||
|
return await dropbox.checkConnectivity(this.dropboxClient);
|
||||||
|
} else {
|
||||||
|
throw Error(`not supported service type ${this.serviceType}`);
|
||||||
|
}
|
||||||
|
};
|
||||||
|
|
||||||
|
getUser = async () => {
|
||||||
|
if (this.serviceType === "dropbox") {
|
||||||
|
return await dropbox.getUserDisplayName(this.dropboxClient);
|
||||||
|
} else {
|
||||||
|
throw Error(`not supported service type ${this.serviceType}`);
|
||||||
|
}
|
||||||
|
};
|
||||||
|
|
||||||
|
revokeAuth = async () => {
|
||||||
|
if (this.serviceType === "dropbox") {
|
||||||
|
return await dropbox.revokeAuth(this.dropboxClient);
|
||||||
} else {
|
} else {
|
||||||
throw Error(`not supported service type ${this.serviceType}`);
|
throw Error(`not supported service type ${this.serviceType}`);
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -0,0 +1,620 @@
|
|||||||
|
import * as path from "path";
|
||||||
|
import { FileStats, Vault } from "obsidian";
|
||||||
|
|
||||||
|
import { Dropbox, DropboxAuth, DropboxResponse, files } from "dropbox";
|
||||||
|
export { Dropbox } from "dropbox";
|
||||||
|
import { RemoteItem, DropboxConfig } from "./baseTypes";
|
||||||
|
import {
|
||||||
|
arrayBufferToBuffer,
|
||||||
|
bufferToArrayBuffer,
|
||||||
|
mkdirpInVault,
|
||||||
|
getPathFolder,
|
||||||
|
getFolderLevels,
|
||||||
|
setToString,
|
||||||
|
} from "./misc";
|
||||||
|
import { decryptArrayBuffer, encryptArrayBuffer } from "./encrypt";
|
||||||
|
|
||||||
|
export const DEFAULT_DROPBOX_CONFIG = {
|
||||||
|
accessToken: "",
|
||||||
|
clientID: process.env.DEFAULT_DROPBOX_APP_KEY,
|
||||||
|
refreshToken: "",
|
||||||
|
accessTokenExpiresInSeconds: 0,
|
||||||
|
accessTokenExpiresAtTime: 0,
|
||||||
|
accountID: "",
|
||||||
|
username: "",
|
||||||
|
};
|
||||||
|
|
||||||
|
export const getDropboxPath = (fileOrFolderPath: string, vaultName: string) => {
|
||||||
|
let key = fileOrFolderPath;
|
||||||
|
if (!fileOrFolderPath.startsWith("/")) {
|
||||||
|
// then this is original path in Obsidian
|
||||||
|
key = `/${vaultName}/${fileOrFolderPath}`;
|
||||||
|
}
|
||||||
|
if (key.endsWith("/")) {
|
||||||
|
key = key.slice(0, key.length - 1);
|
||||||
|
}
|
||||||
|
return key;
|
||||||
|
};
|
||||||
|
|
||||||
|
const getNormPath = (fileOrFolderPath: string, vaultName: string) => {
|
||||||
|
if (
|
||||||
|
!(
|
||||||
|
fileOrFolderPath === `/${vaultName}` ||
|
||||||
|
fileOrFolderPath.startsWith(`/${vaultName}/`)
|
||||||
|
)
|
||||||
|
) {
|
||||||
|
throw Error(`"${fileOrFolderPath}" doesn't starts with "/${vaultName}/"`);
|
||||||
|
}
|
||||||
|
return fileOrFolderPath.slice(`/${vaultName}/`.length);
|
||||||
|
};
|
||||||
|
|
||||||
|
const fromDropboxItemToRemoteItem = (
|
||||||
|
x:
|
||||||
|
| files.FileMetadataReference
|
||||||
|
| files.FolderMetadataReference
|
||||||
|
| files.DeletedMetadataReference,
|
||||||
|
vaultName: string
|
||||||
|
): RemoteItem => {
|
||||||
|
let key = getNormPath(x.path_display, vaultName);
|
||||||
|
if (x[".tag"] === "folder" && !key.endsWith("/")) {
|
||||||
|
key = `${key}/`;
|
||||||
|
}
|
||||||
|
|
||||||
|
if (x[".tag"] === "folder") {
|
||||||
|
return {
|
||||||
|
key: key,
|
||||||
|
lastModified: undefined,
|
||||||
|
size: 0,
|
||||||
|
remoteType: "dropbox",
|
||||||
|
etag: `${x.id}\t`,
|
||||||
|
} as RemoteItem;
|
||||||
|
} else if (x[".tag"] === "file") {
|
||||||
|
return {
|
||||||
|
key: key,
|
||||||
|
lastModified: Date.parse(x.server_modified).valueOf(),
|
||||||
|
size: x.size,
|
||||||
|
remoteType: "dropbox",
|
||||||
|
etag: `${x.id}\t${x.content_hash}`,
|
||||||
|
} as RemoteItem;
|
||||||
|
} else if (x[".tag"] === "deleted") {
|
||||||
|
throw Error("do not support deleted tag");
|
||||||
|
}
|
||||||
|
};
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Dropbox api doesn't return mtime for folders.
|
||||||
|
* This is a try to assign mtime by using files in folder.
|
||||||
|
* @param allFilesFolders
|
||||||
|
* @returns
|
||||||
|
*/
|
||||||
|
const fixLastModifiedTimeInplace = (allFilesFolders: RemoteItem[]) => {
|
||||||
|
if (allFilesFolders.length === 0) {
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
// sort by longer to shorter
|
||||||
|
allFilesFolders.sort((a, b) => b.key.length - a.key.length);
|
||||||
|
|
||||||
|
// a "map" from dir to mtime
|
||||||
|
let potentialMTime = {} as Record<string, number>;
|
||||||
|
|
||||||
|
// first sort pass, from buttom to up
|
||||||
|
for (const item of allFilesFolders) {
|
||||||
|
if (item.key.endsWith("/")) {
|
||||||
|
// itself is a folder, and initially doesn't have mtime
|
||||||
|
if (item.lastModified === undefined && item.key in potentialMTime) {
|
||||||
|
// previously we gathered all sub info of this folder
|
||||||
|
item.lastModified = potentialMTime[item.key];
|
||||||
|
}
|
||||||
|
}
|
||||||
|
const parent = `${path.posix.dirname(item.key)}/`;
|
||||||
|
if (item.lastModified !== undefined) {
|
||||||
|
if (parent in potentialMTime) {
|
||||||
|
potentialMTime[parent] = Math.max(
|
||||||
|
potentialMTime[parent],
|
||||||
|
item.lastModified
|
||||||
|
);
|
||||||
|
} else {
|
||||||
|
potentialMTime[parent] = item.lastModified;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// second pass, from up to buttom.
|
||||||
|
// fill mtime by parent folder or Date.Now() if still not available.
|
||||||
|
// this is only possible if no any sub-folder-files recursively.
|
||||||
|
// we do not sort the array again, just iterate over it by reverse
|
||||||
|
// using good old for loop.
|
||||||
|
for (let i = allFilesFolders.length - 1; i >= 0; --i) {
|
||||||
|
const item = allFilesFolders[i];
|
||||||
|
if (!item.key.endsWith("/")) {
|
||||||
|
continue; // skip files
|
||||||
|
}
|
||||||
|
if (item.lastModified !== undefined) {
|
||||||
|
continue; // don't need to deal with it
|
||||||
|
}
|
||||||
|
const parent = `${path.posix.dirname(item.key)}/`;
|
||||||
|
if (parent in potentialMTime) {
|
||||||
|
item.lastModified = potentialMTime[parent];
|
||||||
|
} else {
|
||||||
|
item.lastModified = Date.now().valueOf();
|
||||||
|
potentialMTime[item.key] = item.lastModified;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
return allFilesFolders;
|
||||||
|
};
|
||||||
|
|
||||||
|
////////////////////////////////////////////////////////////////////////////////
|
||||||
|
// Dropbox authorization using PKCE
|
||||||
|
// see https://dropbox.tech/developers/pkce--what-and-why-
|
||||||
|
////////////////////////////////////////////////////////////////////////////////
|
||||||
|
|
||||||
|
export const getAuthUrlAndVerifier = async (appKey: string) => {
|
||||||
|
const auth = new DropboxAuth({
|
||||||
|
clientId: appKey,
|
||||||
|
});
|
||||||
|
const authUrl = (
|
||||||
|
await auth.getAuthenticationUrl(
|
||||||
|
undefined,
|
||||||
|
undefined,
|
||||||
|
"code",
|
||||||
|
"offline",
|
||||||
|
undefined,
|
||||||
|
"none",
|
||||||
|
true
|
||||||
|
)
|
||||||
|
).toString();
|
||||||
|
const verifier = auth.getCodeVerifier();
|
||||||
|
return {
|
||||||
|
authUrl: authUrl,
|
||||||
|
verifier: verifier,
|
||||||
|
};
|
||||||
|
};
|
||||||
|
|
||||||
|
export interface DropboxSuccessAuthRes {
|
||||||
|
access_token: string;
|
||||||
|
token_type: "bearer";
|
||||||
|
expires_in: string;
|
||||||
|
refresh_token?: string;
|
||||||
|
scope?: string;
|
||||||
|
uid?: string;
|
||||||
|
account_id?: string;
|
||||||
|
}
|
||||||
|
|
||||||
|
export const sendAuthReq = async (
|
||||||
|
appKey: string,
|
||||||
|
verifier: string,
|
||||||
|
authCode: string
|
||||||
|
) => {
|
||||||
|
const resp1 = await fetch("https://api.dropboxapi.com/oauth2/token", {
|
||||||
|
method: "POST",
|
||||||
|
body: new URLSearchParams({
|
||||||
|
code: authCode,
|
||||||
|
grant_type: "authorization_code",
|
||||||
|
code_verifier: verifier,
|
||||||
|
client_id: appKey,
|
||||||
|
}),
|
||||||
|
});
|
||||||
|
const resp2 = (await resp1.json()) as DropboxSuccessAuthRes;
|
||||||
|
return resp2;
|
||||||
|
};
|
||||||
|
|
||||||
|
export const sendRefreshTokenReq = async (
|
||||||
|
appKey: string,
|
||||||
|
refreshToken: string
|
||||||
|
) => {
|
||||||
|
console.log("start auto getting refreshed Dropbox access token.");
|
||||||
|
const resp1 = await fetch("https://api.dropboxapi.com/oauth2/token", {
|
||||||
|
method: "POST",
|
||||||
|
body: new URLSearchParams({
|
||||||
|
grant_type: "refresh_token",
|
||||||
|
refresh_token: refreshToken,
|
||||||
|
client_id: appKey,
|
||||||
|
}),
|
||||||
|
});
|
||||||
|
const resp2 = (await resp1.json()) as DropboxSuccessAuthRes;
|
||||||
|
console.log("finish auto getting refreshed Dropbox access token.");
|
||||||
|
return resp2;
|
||||||
|
};
|
||||||
|
|
||||||
|
export const setConfigBySuccessfullAuthInplace = async (
|
||||||
|
config: DropboxConfig,
|
||||||
|
authRes: DropboxSuccessAuthRes,
|
||||||
|
saveUpdatedConfigFunc: () => Promise<any> | undefined
|
||||||
|
) => {
|
||||||
|
console.log("start updating local info of Dropbox token");
|
||||||
|
|
||||||
|
config.accessToken = authRes.access_token;
|
||||||
|
config.accessTokenExpiresInSeconds = parseInt(authRes.expires_in);
|
||||||
|
config.accessTokenExpiresAtTime =
|
||||||
|
Date.now() + parseInt(authRes.expires_in) * 1000 - 10 * 1000;
|
||||||
|
|
||||||
|
if (authRes.refresh_token !== undefined) {
|
||||||
|
config.refreshToken = authRes.refresh_token;
|
||||||
|
}
|
||||||
|
if (authRes.refresh_token !== undefined) {
|
||||||
|
config.accountID = authRes.account_id;
|
||||||
|
}
|
||||||
|
|
||||||
|
if (saveUpdatedConfigFunc !== undefined) {
|
||||||
|
await saveUpdatedConfigFunc();
|
||||||
|
}
|
||||||
|
|
||||||
|
console.log("finish updating local info of Dropbox token");
|
||||||
|
};
|
||||||
|
|
||||||
|
////////////////////////////////////////////////////////////////////////////////
|
||||||
|
// Other usual common methods
|
||||||
|
////////////////////////////////////////////////////////////////////////////////
|
||||||
|
|
||||||
|
export class WrappedDropboxClient {
|
||||||
|
dropboxConfig: DropboxConfig;
|
||||||
|
vaultName: string;
|
||||||
|
saveUpdatedConfigFunc: () => Promise<any>;
|
||||||
|
dropbox: Dropbox;
|
||||||
|
vaultFolderExists: boolean;
|
||||||
|
constructor(
|
||||||
|
dropboxConfig: DropboxConfig,
|
||||||
|
vaultName: string,
|
||||||
|
saveUpdatedConfigFunc: () => Promise<any>
|
||||||
|
) {
|
||||||
|
this.dropboxConfig = dropboxConfig;
|
||||||
|
this.vaultName = vaultName;
|
||||||
|
this.saveUpdatedConfigFunc = saveUpdatedConfigFunc;
|
||||||
|
this.vaultFolderExists = false;
|
||||||
|
}
|
||||||
|
|
||||||
|
init = async () => {
|
||||||
|
// check token
|
||||||
|
if (
|
||||||
|
this.dropboxConfig.accessToken === "" ||
|
||||||
|
this.dropboxConfig.refreshToken === ""
|
||||||
|
) {
|
||||||
|
throw Error("The user has not manually auth yet.");
|
||||||
|
}
|
||||||
|
const currentTs = Date.now();
|
||||||
|
if (this.dropboxConfig.accessTokenExpiresAtTime > currentTs) {
|
||||||
|
this.dropbox = new Dropbox({
|
||||||
|
accessToken: this.dropboxConfig.accessToken,
|
||||||
|
});
|
||||||
|
} else {
|
||||||
|
if (this.dropboxConfig.refreshToken === "") {
|
||||||
|
throw Error(
|
||||||
|
"We need to automatically refresh token but none is stored."
|
||||||
|
);
|
||||||
|
}
|
||||||
|
const resp = await sendRefreshTokenReq(
|
||||||
|
this.dropboxConfig.clientID,
|
||||||
|
this.dropboxConfig.refreshToken
|
||||||
|
);
|
||||||
|
|
||||||
|
setConfigBySuccessfullAuthInplace(
|
||||||
|
this.dropboxConfig,
|
||||||
|
resp,
|
||||||
|
this.saveUpdatedConfigFunc
|
||||||
|
);
|
||||||
|
this.dropbox = new Dropbox({
|
||||||
|
accessToken: this.dropboxConfig.accessToken,
|
||||||
|
});
|
||||||
|
}
|
||||||
|
|
||||||
|
// check vault folder
|
||||||
|
// console.log(`checking remote has folder /${this.vaultName}`);
|
||||||
|
if (this.vaultFolderExists) {
|
||||||
|
// console.log(`already checked, /${this.vaultName} exist before`)
|
||||||
|
} else {
|
||||||
|
const res = await this.dropbox.filesListFolder({
|
||||||
|
path: "",
|
||||||
|
recursive: false,
|
||||||
|
});
|
||||||
|
for (const item of res.result.entries) {
|
||||||
|
if (item.path_display === `/${this.vaultName}`) {
|
||||||
|
this.vaultFolderExists = true;
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
if (!this.vaultFolderExists) {
|
||||||
|
console.log(`remote does not have folder /${this.vaultName}`);
|
||||||
|
await this.dropbox.filesCreateFolderV2({
|
||||||
|
path: `/${this.vaultName}`,
|
||||||
|
});
|
||||||
|
console.log(`remote folder /${this.vaultName} created`);
|
||||||
|
} else {
|
||||||
|
// console.log(`remote folder /${this.vaultName} exists`);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
return this.dropbox;
|
||||||
|
};
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* @param dropboxConfig
|
||||||
|
* @returns
|
||||||
|
*/
|
||||||
|
export const getDropboxClient = (
|
||||||
|
dropboxConfig: DropboxConfig,
|
||||||
|
vaultName: string,
|
||||||
|
saveUpdatedConfigFunc: () => Promise<any>
|
||||||
|
) => {
|
||||||
|
return new WrappedDropboxClient(
|
||||||
|
dropboxConfig,
|
||||||
|
vaultName,
|
||||||
|
saveUpdatedConfigFunc
|
||||||
|
);
|
||||||
|
};
|
||||||
|
|
||||||
|
export const getRemoteMeta = async (
|
||||||
|
client: WrappedDropboxClient,
|
||||||
|
fileOrFolderPath: string
|
||||||
|
) => {
|
||||||
|
await client.init();
|
||||||
|
if (fileOrFolderPath === "" || fileOrFolderPath === "/") {
|
||||||
|
// filesGetMetadata doesn't support root folder
|
||||||
|
// we instead try to list files
|
||||||
|
// if no error occurs, we ensemble a fake result.
|
||||||
|
const rsp = await client.dropbox.filesListFolder({
|
||||||
|
path: `/${client.vaultName}`,
|
||||||
|
recursive: false, // don't need to recursive here
|
||||||
|
});
|
||||||
|
if (rsp.status !== 200) {
|
||||||
|
throw Error(JSON.stringify(rsp));
|
||||||
|
}
|
||||||
|
return {
|
||||||
|
key: fileOrFolderPath,
|
||||||
|
lastModified: undefined,
|
||||||
|
size: 0,
|
||||||
|
remoteType: "dropbox",
|
||||||
|
etag: undefined,
|
||||||
|
} as RemoteItem;
|
||||||
|
}
|
||||||
|
|
||||||
|
const key = getDropboxPath(fileOrFolderPath, client.vaultName);
|
||||||
|
|
||||||
|
const rsp = await client.dropbox.filesGetMetadata({
|
||||||
|
path: key,
|
||||||
|
});
|
||||||
|
if (rsp.status !== 200) {
|
||||||
|
throw Error(JSON.stringify(rsp));
|
||||||
|
}
|
||||||
|
return fromDropboxItemToRemoteItem(rsp.result, client.vaultName);
|
||||||
|
};
|
||||||
|
|
||||||
|
export const uploadToRemote = async (
|
||||||
|
client: WrappedDropboxClient,
|
||||||
|
fileOrFolderPath: string,
|
||||||
|
vault: Vault,
|
||||||
|
isRecursively: boolean = false,
|
||||||
|
password: string = "",
|
||||||
|
remoteEncryptedKey: string = "",
|
||||||
|
foldersCreatedBefore: Set<string> | undefined = undefined
|
||||||
|
) => {
|
||||||
|
await client.init();
|
||||||
|
|
||||||
|
let uploadFile = fileOrFolderPath;
|
||||||
|
if (password !== "") {
|
||||||
|
uploadFile = remoteEncryptedKey;
|
||||||
|
}
|
||||||
|
uploadFile = getDropboxPath(uploadFile, client.vaultName);
|
||||||
|
|
||||||
|
const isFolder = fileOrFolderPath.endsWith("/");
|
||||||
|
|
||||||
|
if (isFolder && isRecursively) {
|
||||||
|
throw Error("upload function doesn't implement recursive function yet!");
|
||||||
|
} else if (isFolder && !isRecursively) {
|
||||||
|
// folder
|
||||||
|
if (password === "") {
|
||||||
|
// if not encrypted, mkdir a remote folder
|
||||||
|
if (foldersCreatedBefore?.has(uploadFile)) {
|
||||||
|
// created, pass
|
||||||
|
} else {
|
||||||
|
try {
|
||||||
|
await client.dropbox.filesCreateFolderV2({
|
||||||
|
path: uploadFile,
|
||||||
|
});
|
||||||
|
foldersCreatedBefore?.add(uploadFile);
|
||||||
|
} catch (err) {
|
||||||
|
if (err.status === 409) {
|
||||||
|
// pass
|
||||||
|
foldersCreatedBefore?.add(uploadFile);
|
||||||
|
} else {
|
||||||
|
throw err;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
const res = await getRemoteMeta(client, uploadFile);
|
||||||
|
return res;
|
||||||
|
} else {
|
||||||
|
// if encrypted, upload a fake file with the encrypted file name
|
||||||
|
await client.dropbox.filesUpload({
|
||||||
|
path: uploadFile,
|
||||||
|
contents: "",
|
||||||
|
});
|
||||||
|
return await getRemoteMeta(client, uploadFile);
|
||||||
|
}
|
||||||
|
} else {
|
||||||
|
// file
|
||||||
|
// we ignore isRecursively parameter here
|
||||||
|
const localContent = await vault.adapter.readBinary(fileOrFolderPath);
|
||||||
|
let remoteContent = localContent;
|
||||||
|
if (password !== "") {
|
||||||
|
remoteContent = await encryptArrayBuffer(localContent, password);
|
||||||
|
}
|
||||||
|
// in dropbox, we don't need to create folders before uploading! cool!
|
||||||
|
// TODO: filesUploadSession for larger files (>=150 MB)
|
||||||
|
await client.dropbox.filesUpload({
|
||||||
|
path: uploadFile,
|
||||||
|
contents: remoteContent,
|
||||||
|
mode: {
|
||||||
|
".tag": "overwrite",
|
||||||
|
},
|
||||||
|
});
|
||||||
|
// we want to mark that parent folders are created
|
||||||
|
if (foldersCreatedBefore !== undefined) {
|
||||||
|
const dirs = getFolderLevels(uploadFile).map((x) =>
|
||||||
|
getDropboxPath(x, client.vaultName)
|
||||||
|
);
|
||||||
|
for (const dir of dirs) {
|
||||||
|
foldersCreatedBefore?.add(dir);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return await getRemoteMeta(client, uploadFile);
|
||||||
|
}
|
||||||
|
};
|
||||||
|
|
||||||
|
export const listFromRemote = async (
|
||||||
|
client: WrappedDropboxClient,
|
||||||
|
prefix?: string
|
||||||
|
) => {
|
||||||
|
if (prefix !== undefined) {
|
||||||
|
throw Error("prefix not supported (yet)");
|
||||||
|
}
|
||||||
|
await client.init();
|
||||||
|
let res = await client.dropbox.filesListFolder({
|
||||||
|
path: `/${client.vaultName}`,
|
||||||
|
recursive: true,
|
||||||
|
include_deleted: false,
|
||||||
|
limit: 1000,
|
||||||
|
});
|
||||||
|
if (res.status !== 200) {
|
||||||
|
throw Error(JSON.stringify(res));
|
||||||
|
}
|
||||||
|
// console.log(res);
|
||||||
|
|
||||||
|
const contents = res.result.entries;
|
||||||
|
const unifiedContents = contents
|
||||||
|
.filter((x) => x[".tag"] !== "deleted")
|
||||||
|
.filter((x) => x.path_display !== `/${client.vaultName}`)
|
||||||
|
.map((x) => fromDropboxItemToRemoteItem(x, client.vaultName));
|
||||||
|
|
||||||
|
while (res.result.has_more) {
|
||||||
|
res = await client.dropbox.filesListFolderContinue({
|
||||||
|
cursor: res.result.cursor,
|
||||||
|
});
|
||||||
|
if (res.status !== 200) {
|
||||||
|
throw Error(JSON.stringify(res));
|
||||||
|
}
|
||||||
|
|
||||||
|
const contents2 = res.result.entries;
|
||||||
|
const unifiedContents2 = contents2
|
||||||
|
.filter((x) => x[".tag"] !== "deleted")
|
||||||
|
.filter((x) => x.path_display !== `/${client.vaultName}`)
|
||||||
|
.map((x) => fromDropboxItemToRemoteItem(x, client.vaultName));
|
||||||
|
unifiedContents.push(...unifiedContents2);
|
||||||
|
}
|
||||||
|
|
||||||
|
fixLastModifiedTimeInplace(unifiedContents);
|
||||||
|
|
||||||
|
return {
|
||||||
|
Contents: unifiedContents,
|
||||||
|
};
|
||||||
|
};
|
||||||
|
|
||||||
|
const downloadFromRemoteRaw = async (
|
||||||
|
client: WrappedDropboxClient,
|
||||||
|
fileOrFolderPath: string
|
||||||
|
) => {
|
||||||
|
await client.init();
|
||||||
|
const key = getDropboxPath(fileOrFolderPath, client.vaultName);
|
||||||
|
const rsp = await client.dropbox.filesDownload({
|
||||||
|
path: key,
|
||||||
|
});
|
||||||
|
if ((rsp.result as any).fileBlob !== undefined) {
|
||||||
|
// we get a Blob
|
||||||
|
const content = (rsp.result as any).fileBlob as Blob;
|
||||||
|
return await content.arrayBuffer();
|
||||||
|
} else if ((rsp.result as any).fileBinary !== undefined) {
|
||||||
|
// we get a Buffer
|
||||||
|
const content = (rsp.result as any).fileBinary as Buffer;
|
||||||
|
return bufferToArrayBuffer(content);
|
||||||
|
} else {
|
||||||
|
throw Error(`unknown rsp from dropbox download: ${rsp}`);
|
||||||
|
}
|
||||||
|
};
|
||||||
|
|
||||||
|
export const downloadFromRemote = async (
|
||||||
|
client: WrappedDropboxClient,
|
||||||
|
fileOrFolderPath: string,
|
||||||
|
vault: Vault,
|
||||||
|
mtime: number,
|
||||||
|
password: string = "",
|
||||||
|
remoteEncryptedKey: string = ""
|
||||||
|
) => {
|
||||||
|
const isFolder = fileOrFolderPath.endsWith("/");
|
||||||
|
|
||||||
|
await mkdirpInVault(fileOrFolderPath, vault);
|
||||||
|
|
||||||
|
// the file is always local file
|
||||||
|
// we need to encrypt it
|
||||||
|
|
||||||
|
if (isFolder) {
|
||||||
|
// mkdirp locally is enough
|
||||||
|
// do nothing here
|
||||||
|
} else {
|
||||||
|
let downloadFile = fileOrFolderPath;
|
||||||
|
if (password !== "") {
|
||||||
|
downloadFile = remoteEncryptedKey;
|
||||||
|
}
|
||||||
|
downloadFile = getDropboxPath(downloadFile, client.vaultName);
|
||||||
|
const remoteContent = await downloadFromRemoteRaw(client, downloadFile);
|
||||||
|
let localContent = remoteContent;
|
||||||
|
if (password !== "") {
|
||||||
|
localContent = await decryptArrayBuffer(remoteContent, password);
|
||||||
|
}
|
||||||
|
await vault.adapter.writeBinary(fileOrFolderPath, localContent, {
|
||||||
|
mtime: mtime,
|
||||||
|
});
|
||||||
|
}
|
||||||
|
};
|
||||||
|
|
||||||
|
export const deleteFromRemote = async (
|
||||||
|
client: WrappedDropboxClient,
|
||||||
|
fileOrFolderPath: string,
|
||||||
|
password: string = "",
|
||||||
|
remoteEncryptedKey: string = ""
|
||||||
|
) => {
|
||||||
|
if (fileOrFolderPath === "/") {
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
let remoteFileName = fileOrFolderPath;
|
||||||
|
if (password !== "") {
|
||||||
|
remoteFileName = remoteEncryptedKey;
|
||||||
|
}
|
||||||
|
remoteFileName = getDropboxPath(remoteFileName, client.vaultName);
|
||||||
|
|
||||||
|
await client.init();
|
||||||
|
try {
|
||||||
|
await client.dropbox.filesDeleteV2({
|
||||||
|
path: remoteFileName,
|
||||||
|
});
|
||||||
|
} catch (err) {
|
||||||
|
console.error("some error while deleting");
|
||||||
|
console.error(err);
|
||||||
|
}
|
||||||
|
};
|
||||||
|
|
||||||
|
export const checkConnectivity = async (client: WrappedDropboxClient) => {
|
||||||
|
try {
|
||||||
|
const results = await getRemoteMeta(client, "/");
|
||||||
|
if (results === undefined) {
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
return true;
|
||||||
|
} catch (err) {
|
||||||
|
console.error("dropbox connectivity error:");
|
||||||
|
console.error(err);
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
};
|
||||||
|
|
||||||
|
export const getUserDisplayName = async (client: WrappedDropboxClient) => {
|
||||||
|
await client.init();
|
||||||
|
const acct = await client.dropbox.usersGetCurrentAccount();
|
||||||
|
return acct.result.name.display_name;
|
||||||
|
};
|
||||||
|
|
||||||
|
export const revokeAuth = async (client: WrappedDropboxClient) => {
|
||||||
|
await client.init();
|
||||||
|
await client.dropbox.authTokenRevoke();
|
||||||
|
};
|
||||||
@@ -27,17 +27,9 @@ import {
|
|||||||
} from "./misc";
|
} from "./misc";
|
||||||
import * as mime from "mime-types";
|
import * as mime from "mime-types";
|
||||||
|
|
||||||
import { RemoteItem } from "./baseTypes";
|
import { RemoteItem, S3Config } from "./baseTypes";
|
||||||
import { decryptArrayBuffer, encryptArrayBuffer } from "./encrypt";
|
import { decryptArrayBuffer, encryptArrayBuffer } from "./encrypt";
|
||||||
|
|
||||||
export interface S3Config {
|
|
||||||
s3Endpoint: string;
|
|
||||||
s3Region: string;
|
|
||||||
s3AccessKeyID: string;
|
|
||||||
s3SecretAccessKey: string;
|
|
||||||
s3BucketName: string;
|
|
||||||
}
|
|
||||||
|
|
||||||
export const DEFAULT_S3_CONFIG = {
|
export const DEFAULT_S3_CONFIG = {
|
||||||
s3Endpoint: "",
|
s3Endpoint: "",
|
||||||
s3Region: "",
|
s3Region: "",
|
||||||
@@ -225,12 +217,12 @@ const getObjectBodyToArrayBuffer = async (
|
|||||||
b: Readable | ReadableStream | Blob
|
b: Readable | ReadableStream | Blob
|
||||||
) => {
|
) => {
|
||||||
if (b instanceof Readable) {
|
if (b instanceof Readable) {
|
||||||
|
return (await new Promise((resolve, reject) => {
|
||||||
const chunks: Uint8Array[] = [];
|
const chunks: Uint8Array[] = [];
|
||||||
for await (let chunk of b) {
|
b.on("data", (chunk) => chunks.push(chunk));
|
||||||
chunks.push(chunk);
|
b.on("error", reject);
|
||||||
}
|
b.on("end", () => resolve(bufferToArrayBuffer(Buffer.concat(chunks))));
|
||||||
const buf = Buffer.concat(chunks);
|
})) as ArrayBuffer;
|
||||||
return bufferToArrayBuffer(buf);
|
|
||||||
} else if (b instanceof ReadableStream) {
|
} else if (b instanceof ReadableStream) {
|
||||||
return await new Response(b, {}).arrayBuffer();
|
return await new Response(b, {}).arrayBuffer();
|
||||||
} else if (b instanceof Blob) {
|
} else if (b instanceof Blob) {
|
||||||
@@ -4,7 +4,7 @@ import { AuthType, BufferLike, createClient } from "webdav/web";
|
|||||||
import type { WebDAVClient, ResponseDataDetailed, FileStat } from "webdav/web";
|
import type { WebDAVClient, ResponseDataDetailed, FileStat } from "webdav/web";
|
||||||
export type { WebDAVClient } from "webdav/web";
|
export type { WebDAVClient } from "webdav/web";
|
||||||
|
|
||||||
import type { RemoteItem } from "./baseTypes";
|
import type { RemoteItem, WebdavAuthType, WebdavConfig } from "./baseTypes";
|
||||||
|
|
||||||
import {
|
import {
|
||||||
arrayBufferToBuffer,
|
arrayBufferToBuffer,
|
||||||
@@ -14,15 +14,6 @@ import {
|
|||||||
} from "./misc";
|
} from "./misc";
|
||||||
import { decryptArrayBuffer, encryptArrayBuffer } from "./encrypt";
|
import { decryptArrayBuffer, encryptArrayBuffer } from "./encrypt";
|
||||||
|
|
||||||
export type WebdavAuthType = "digest" | "basic";
|
|
||||||
|
|
||||||
export interface WebdavConfig {
|
|
||||||
address: string;
|
|
||||||
username: string;
|
|
||||||
password: string;
|
|
||||||
authType: WebdavAuthType;
|
|
||||||
}
|
|
||||||
|
|
||||||
export const DEFAULT_WEBDAV_CONFIG = {
|
export const DEFAULT_WEBDAV_CONFIG = {
|
||||||
address: "",
|
address: "",
|
||||||
username: "",
|
username: "",
|
||||||
@@ -226,7 +217,7 @@ export const deleteFromRemote = async (
|
|||||||
remoteFileName = getWebdavPath(remoteFileName);
|
remoteFileName = getWebdavPath(remoteFileName);
|
||||||
try {
|
try {
|
||||||
await client.deleteFile(remoteFileName);
|
await client.deleteFile(remoteFileName);
|
||||||
console.log(`delete ${remoteFileName} succeeded`);
|
// console.log(`delete ${remoteFileName} succeeded`);
|
||||||
} catch (err) {
|
} catch (err) {
|
||||||
console.error("some error while deleting");
|
console.error("some error while deleting");
|
||||||
console.log(err);
|
console.log(err);
|
||||||
+33
-13
@@ -9,7 +9,7 @@ import type { FileFolderHistoryRecord, InternalDBs } from "./localdb";
|
|||||||
|
|
||||||
import { RemoteClient } from "./remote";
|
import { RemoteClient } from "./remote";
|
||||||
import type { SUPPORTED_SERVICES_TYPE, RemoteItem } from "./baseTypes";
|
import type { SUPPORTED_SERVICES_TYPE, RemoteItem } from "./baseTypes";
|
||||||
import { mkdirpInVault, isHiddenPath, isVaildText } from "./misc";
|
import { mkdirpInVault, isHiddenPath, isVaildText, setToString } from "./misc";
|
||||||
import {
|
import {
|
||||||
decryptBase32ToString,
|
decryptBase32ToString,
|
||||||
encryptStringToBase32,
|
encryptStringToBase32,
|
||||||
@@ -389,7 +389,7 @@ const getOperation = (
|
|||||||
}
|
}
|
||||||
|
|
||||||
if (r.decision === "unknown") {
|
if (r.decision === "unknown") {
|
||||||
throw Error(`unknown decision for ${r}`);
|
throw Error(`unknown decision for ${JSON.stringify(r)}`);
|
||||||
}
|
}
|
||||||
|
|
||||||
return r;
|
return r;
|
||||||
@@ -428,7 +428,8 @@ const dispatchOperationToActual = async (
|
|||||||
client: RemoteClient,
|
client: RemoteClient,
|
||||||
db: InternalDBs,
|
db: InternalDBs,
|
||||||
vault: Vault,
|
vault: Vault,
|
||||||
password: string = ""
|
password: string = "",
|
||||||
|
foldersCreatedBefore: Set<string> | undefined = undefined
|
||||||
) => {
|
) => {
|
||||||
let remoteEncryptedKey = key;
|
let remoteEncryptedKey = key;
|
||||||
if (password !== "") {
|
if (password !== "") {
|
||||||
@@ -461,7 +462,8 @@ const dispatchOperationToActual = async (
|
|||||||
vault,
|
vault,
|
||||||
false,
|
false,
|
||||||
password,
|
password,
|
||||||
remoteEncryptedKey
|
remoteEncryptedKey,
|
||||||
|
foldersCreatedBefore
|
||||||
);
|
);
|
||||||
await upsertSyncMetaMappingData(
|
await upsertSyncMetaMappingData(
|
||||||
client.serviceType,
|
client.serviceType,
|
||||||
@@ -493,7 +495,8 @@ const dispatchOperationToActual = async (
|
|||||||
vault,
|
vault,
|
||||||
false,
|
false,
|
||||||
password,
|
password,
|
||||||
remoteEncryptedKey
|
remoteEncryptedKey,
|
||||||
|
foldersCreatedBefore
|
||||||
);
|
);
|
||||||
await upsertSyncMetaMappingData(
|
await upsertSyncMetaMappingData(
|
||||||
client.serviceType,
|
client.serviceType,
|
||||||
@@ -521,18 +524,35 @@ export const doActualSync = async (
|
|||||||
password: string = ""
|
password: string = ""
|
||||||
) => {
|
) => {
|
||||||
const keyStates = syncPlan.mixedStates;
|
const keyStates = syncPlan.mixedStates;
|
||||||
await Promise.all(
|
const foldersCreatedBefore = new Set<string>();
|
||||||
Object.entries(keyStates)
|
for (const [k, v] of Object.entries(keyStates).sort(
|
||||||
.sort((k, v) => -(k as string).length)
|
([k1, v1], [k2, v2]) => k2.length - k1.length
|
||||||
.map(async ([k, v]) =>
|
)) {
|
||||||
dispatchOperationToActual(
|
const k2 = k as string;
|
||||||
|
const v2 = v as FileOrFolderMixedState;
|
||||||
|
await dispatchOperationToActual(
|
||||||
k as string,
|
k as string,
|
||||||
v as FileOrFolderMixedState,
|
v as FileOrFolderMixedState,
|
||||||
client,
|
client,
|
||||||
db,
|
db,
|
||||||
vault,
|
vault,
|
||||||
password
|
password,
|
||||||
)
|
foldersCreatedBefore
|
||||||
)
|
|
||||||
);
|
);
|
||||||
|
// console.log(`finished ${k}, with ${setToString(foldersCreatedBefore)}`);
|
||||||
|
}
|
||||||
|
// await Promise.all(
|
||||||
|
// Object.entries(keyStates)
|
||||||
|
// .map(async ([k, v]) =>
|
||||||
|
// dispatchOperationToActual(
|
||||||
|
// k as string,
|
||||||
|
// v as FileOrFolderMixedState,
|
||||||
|
// client,
|
||||||
|
// db,
|
||||||
|
// vault,
|
||||||
|
// password,
|
||||||
|
// foldersCreatedBefore
|
||||||
|
// )
|
||||||
|
// )
|
||||||
|
// );
|
||||||
};
|
};
|
||||||
|
|||||||
+20
-1
@@ -11,10 +11,29 @@
|
|||||||
display: none;
|
display: none;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
.dropbox-disclaimer {
|
||||||
|
font-weight: bold;
|
||||||
|
}
|
||||||
|
.dropbox-hide {
|
||||||
|
display: none;
|
||||||
|
}
|
||||||
|
|
||||||
|
.dropbox-auth-button-hide {
|
||||||
|
display: none;
|
||||||
|
}
|
||||||
|
|
||||||
|
.dropbox-revoke-auth-button-hide {
|
||||||
|
display: none;
|
||||||
|
}
|
||||||
|
|
||||||
.webdav-disclaimer {
|
.webdav-disclaimer {
|
||||||
font-weight: bold;
|
font-weight: bold;
|
||||||
}
|
}
|
||||||
|
|
||||||
.webdav-hide {
|
.webdav-hide {
|
||||||
display: none;
|
display: none;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
.qrcode-img {
|
||||||
|
width: 350px;
|
||||||
|
height: 350px;
|
||||||
|
}
|
||||||
|
|||||||
@@ -69,6 +69,28 @@ describe("Misc: get folder levels", () => {
|
|||||||
const res3 = ["xxx", "xxx/yyy", "xxx/yyy/zzz"];
|
const res3 = ["xxx", "xxx/yyy", "xxx/yyy/zzz"];
|
||||||
expect(misc.getFolderLevels(item3)).to.deep.equal(res3);
|
expect(misc.getFolderLevels(item3)).to.deep.equal(res3);
|
||||||
});
|
});
|
||||||
|
|
||||||
|
it("should treat path starting with / correctly", () => {
|
||||||
|
const item = "/xxx/yyy/zzz.md";
|
||||||
|
const res = ["/xxx", "/xxx/yyy"];
|
||||||
|
expect(misc.getFolderLevels(item)).to.deep.equal(res);
|
||||||
|
|
||||||
|
const item2 = "/xxx/yyy/zzz";
|
||||||
|
const res2 = ["/xxx", "/xxx/yyy"];
|
||||||
|
expect(misc.getFolderLevels(item2)).to.deep.equal(res2);
|
||||||
|
|
||||||
|
const item3 = "/xxx/yyy/zzz/";
|
||||||
|
const res3 = ["/xxx", "/xxx/yyy", "/xxx/yyy/zzz"];
|
||||||
|
expect(misc.getFolderLevels(item3)).to.deep.equal(res3);
|
||||||
|
|
||||||
|
const item4 = "/xxx";
|
||||||
|
const res4 = [] as string[];
|
||||||
|
expect(misc.getFolderLevels(item4)).to.deep.equal(res4);
|
||||||
|
|
||||||
|
const item5 = "/";
|
||||||
|
const res5 = [] as string[];
|
||||||
|
expect(misc.getFolderLevels(item5)).to.deep.equal(res5);
|
||||||
|
});
|
||||||
});
|
});
|
||||||
|
|
||||||
describe("Misc: vaild file name tests", () => {
|
describe("Misc: vaild file name tests", () => {
|
||||||
|
|||||||
@@ -11,6 +11,7 @@
|
|||||||
// "allowSyntheticDefaultImports": true,
|
// "allowSyntheticDefaultImports": true,
|
||||||
"esModuleInterop": true,
|
"esModuleInterop": true,
|
||||||
"importHelpers": true,
|
"importHelpers": true,
|
||||||
|
"isolatedModules": true,
|
||||||
"lib": ["dom", "es5", "scripthost", "es2015"]
|
"lib": ["dom", "es5", "scripthost", "es2015"]
|
||||||
},
|
},
|
||||||
"include": ["**/*.ts"]
|
"include": ["**/*.ts"]
|
||||||
|
|||||||
+1
-1
@@ -1,3 +1,3 @@
|
|||||||
{
|
{
|
||||||
"0.1.6": "0.12.15"
|
"0.2.3": "0.12.15"
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -1,7 +1,10 @@
|
|||||||
|
require("dotenv").config();
|
||||||
const path = require("path");
|
const path = require("path");
|
||||||
const webpack = require("webpack");
|
const webpack = require("webpack");
|
||||||
const TerserPlugin = require("terser-webpack-plugin");
|
const TerserPlugin = require("terser-webpack-plugin");
|
||||||
|
|
||||||
|
const DEFAULT_DROPBOX_APP_KEY = process.env.DROPBOX_APP_KEY || "";
|
||||||
|
|
||||||
module.exports = {
|
module.exports = {
|
||||||
entry: "./src/main.ts",
|
entry: "./src/main.ts",
|
||||||
target: "web",
|
target: "web",
|
||||||
@@ -11,6 +14,9 @@ module.exports = {
|
|||||||
libraryTarget: "commonjs",
|
libraryTarget: "commonjs",
|
||||||
},
|
},
|
||||||
plugins: [
|
plugins: [
|
||||||
|
new webpack.DefinePlugin({
|
||||||
|
"process.env.DEFAULT_DROPBOX_APP_KEY": `"${DEFAULT_DROPBOX_APP_KEY}"`,
|
||||||
|
}),
|
||||||
// Work around for Buffer is undefined:
|
// Work around for Buffer is undefined:
|
||||||
// https://github.com/webpack/changelog-v5/issues/10
|
// https://github.com/webpack/changelog-v5/issues/10
|
||||||
new webpack.ProvidePlugin({
|
new webpack.ProvidePlugin({
|
||||||
@@ -38,6 +44,7 @@ module.exports = {
|
|||||||
// console: require.resolve("console-browserify"),
|
// console: require.resolve("console-browserify"),
|
||||||
// constants: require.resolve("constants-browserify"),
|
// constants: require.resolve("constants-browserify"),
|
||||||
// crypto: require.resolve("crypto-browserify"),
|
// crypto: require.resolve("crypto-browserify"),
|
||||||
|
crypto: false,
|
||||||
// domain: require.resolve("domain-browser"),
|
// domain: require.resolve("domain-browser"),
|
||||||
// events: require.resolve("events"),
|
// events: require.resolve("events"),
|
||||||
// http: require.resolve("stream-http"),
|
// http: require.resolve("stream-http"),
|
||||||
|
|||||||
Reference in New Issue
Block a user