Compare commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
5e3d413b33 | ||
|
|
bcf8586fbf | ||
|
|
6431182ec3 | ||
|
|
cef623f493 | ||
|
|
0c00c1a2e3 | ||
|
|
ab8805f272 | ||
|
|
da180fcc92 |
+1
-1
@@ -1,7 +1,7 @@
|
||||
{
|
||||
"id": "obsdian-save-remote",
|
||||
"name": "Save remote",
|
||||
"version": "0.0.3",
|
||||
"version": "0.0.5",
|
||||
"minAppVersion": "0.12.15",
|
||||
"description": "This is yet another plugin allowing users to sync notes between local device and the cloud.",
|
||||
"author": "fyears",
|
||||
|
||||
+2
-3
@@ -1,6 +1,6 @@
|
||||
{
|
||||
"name": "obsidian-save-remote",
|
||||
"version": "0.0.1",
|
||||
"version": "0.0.5",
|
||||
"description": "This is yet another sync plugin for Obsidian app.",
|
||||
"scripts": {
|
||||
"dev": "webpack --mode development --watch",
|
||||
@@ -13,7 +13,6 @@
|
||||
"author": "",
|
||||
"license": "Apache-2.0",
|
||||
"devDependencies": {
|
||||
"@types/crypto-js": "^4.0.2",
|
||||
"@types/node": "^14.14.37",
|
||||
"prettier": "^2.4.1",
|
||||
"terser-webpack-plugin": "^5.2.4",
|
||||
@@ -37,9 +36,9 @@
|
||||
"console-browserify": "^1.2.0",
|
||||
"constants-browserify": "^1.0.0",
|
||||
"crypto-browserify": "^3.12.0",
|
||||
"crypto-js": "^4.1.1",
|
||||
"domain-browser": "^4.22.0",
|
||||
"events": "^3.3.0",
|
||||
"hash-wasm": "^4.9.0",
|
||||
"hi-base32": "^0.5.1",
|
||||
"https-browserify": "^1.0.0",
|
||||
"lovefield-ts": "^0.7.0",
|
||||
|
||||
+57
-71
@@ -1,113 +1,99 @@
|
||||
import * as CryptoJS from "crypto-js";
|
||||
import { randomBytes, createDecipheriv, createCipheriv } from "crypto";
|
||||
import { pbkdf2, createSHA256 } from "hash-wasm";
|
||||
import { promisify } from "util";
|
||||
import * as base32 from "hi-base32";
|
||||
import {
|
||||
bufferToArrayBuffer,
|
||||
arrayBufferToBuffer,
|
||||
arrayBufferToBase64,
|
||||
base64ToArrayBuffer,
|
||||
} from "./misc";
|
||||
import { bufferToArrayBuffer, arrayBufferToBuffer } from "./misc";
|
||||
|
||||
const DEFAULT_ITER = 10000;
|
||||
|
||||
export const encryptWordArray = (
|
||||
wa: CryptoJS.lib.WordArray,
|
||||
export const encryptBuffer = async (
|
||||
buf: Buffer,
|
||||
password: string,
|
||||
rounds: number = DEFAULT_ITER
|
||||
) => {
|
||||
const prefix = CryptoJS.enc.Utf8.parse("Salted__");
|
||||
const salt = CryptoJS.lib.WordArray.random(8);
|
||||
const derivedKey = CryptoJS.PBKDF2(password, salt, {
|
||||
keySize: 32 + 16,
|
||||
const salt = await promisify(randomBytes)(8);
|
||||
const derivedKey = await pbkdf2({
|
||||
password: password,
|
||||
salt: salt,
|
||||
iterations: rounds,
|
||||
hasher: CryptoJS.algo.SHA256,
|
||||
hashLength: 32 + 16,
|
||||
hashFunction: createSHA256(),
|
||||
outputType: "binary",
|
||||
});
|
||||
const key = CryptoJS.lib.WordArray.create(derivedKey.words.slice(0, 32 / 4));
|
||||
const iv = CryptoJS.lib.WordArray.create(
|
||||
derivedKey.words.slice(32 / 4, (32 + 16) / 4)
|
||||
);
|
||||
const encrypted = CryptoJS.AES.encrypt(wa, key, { iv: iv }).ciphertext;
|
||||
const res = CryptoJS.lib.WordArray.create()
|
||||
.concat(prefix)
|
||||
.concat(salt)
|
||||
.concat(encrypted);
|
||||
const key = derivedKey.slice(0, 32);
|
||||
const iv = derivedKey.slice(32, 32 + 16);
|
||||
const cipher = createCipheriv("aes-256-cbc", key, iv);
|
||||
cipher.write(buf);
|
||||
cipher.end();
|
||||
const encrypted = cipher.read();
|
||||
const res = Buffer.concat([Buffer.from("Salted__"), salt, encrypted]);
|
||||
return res;
|
||||
};
|
||||
|
||||
export const decryptWordArray = (
|
||||
wa: CryptoJS.lib.WordArray,
|
||||
export const decryptBuffer = async (
|
||||
buf: Buffer,
|
||||
password: string,
|
||||
rounds: number = DEFAULT_ITER
|
||||
) => {
|
||||
const prefix = CryptoJS.lib.WordArray.create(wa.words.slice(0, 8 / 4));
|
||||
|
||||
const salt = CryptoJS.lib.WordArray.create(
|
||||
wa.words.slice(8 / 4, (8 + 8) / 4)
|
||||
);
|
||||
const derivedKey = CryptoJS.PBKDF2(password, salt, {
|
||||
keySize: 32 + 16,
|
||||
const prefix = buf.slice(0, 8);
|
||||
const salt = buf.slice(8, 16);
|
||||
const derivedKey = await pbkdf2({
|
||||
password: password,
|
||||
salt: salt,
|
||||
iterations: rounds,
|
||||
hasher: CryptoJS.algo.SHA256,
|
||||
hashLength: 32 + 16,
|
||||
hashFunction: createSHA256(),
|
||||
outputType: "binary",
|
||||
});
|
||||
const key = CryptoJS.lib.WordArray.create(derivedKey.words.slice(0, 32 / 4));
|
||||
const iv = CryptoJS.lib.WordArray.create(
|
||||
derivedKey.words.slice(32 / 4, 32 / 4 + 16 / 4)
|
||||
);
|
||||
const decrypted = CryptoJS.AES.decrypt(
|
||||
CryptoJS.lib.CipherParams.create({
|
||||
ciphertext: CryptoJS.lib.WordArray.create(wa.words.slice((8 + 8) / 4)),
|
||||
}),
|
||||
key,
|
||||
{ iv: iv }
|
||||
);
|
||||
return decrypted;
|
||||
const key = derivedKey.slice(0, 32);
|
||||
const iv = derivedKey.slice(32, 32 + 16);
|
||||
const decipher = createDecipheriv("aes-256-cbc", key, iv);
|
||||
decipher.write(buf.slice(16));
|
||||
decipher.end();
|
||||
const decrypted = decipher.read();
|
||||
return decrypted as Buffer;
|
||||
};
|
||||
|
||||
export const encryptArrayBuffer = (
|
||||
export const encryptArrayBuffer = async (
|
||||
arrBuf: ArrayBuffer,
|
||||
password: string,
|
||||
rounds: number = DEFAULT_ITER
|
||||
) => {
|
||||
const b64 = arrayBufferToBase64(arrBuf);
|
||||
const wa = CryptoJS.enc.Base64.parse(b64);
|
||||
const enc = encryptWordArray(wa, password, rounds);
|
||||
const resb64 = CryptoJS.enc.Base64.stringify(enc);
|
||||
const res = base64ToArrayBuffer(resb64);
|
||||
return res;
|
||||
return bufferToArrayBuffer(
|
||||
await encryptBuffer(arrayBufferToBuffer(arrBuf), password, rounds)
|
||||
);
|
||||
};
|
||||
|
||||
export const decryptArrayBuffer = (
|
||||
export const decryptArrayBuffer = async (
|
||||
arrBuf: ArrayBuffer,
|
||||
password: string,
|
||||
rounds: number = DEFAULT_ITER
|
||||
) => {
|
||||
const b64 = arrayBufferToBase64(arrBuf);
|
||||
const wa = CryptoJS.enc.Base64.parse(b64);
|
||||
const dec = decryptWordArray(wa, password, rounds);
|
||||
const resb64 = CryptoJS.enc.Base64.stringify(dec);
|
||||
const res = base64ToArrayBuffer(resb64);
|
||||
return res;
|
||||
return bufferToArrayBuffer(
|
||||
await decryptBuffer(arrayBufferToBuffer(arrBuf), password, rounds)
|
||||
);
|
||||
};
|
||||
|
||||
export const encryptStringToBase32 = (
|
||||
export const encryptStringToBase32 = async (
|
||||
text: string,
|
||||
password: string,
|
||||
rounds: number = DEFAULT_ITER
|
||||
) => {
|
||||
const wa = CryptoJS.enc.Utf8.parse(text);
|
||||
const enc = encryptWordArray(wa, password, rounds);
|
||||
const enctext = CryptoJS.enc.Base64.stringify(enc);
|
||||
const res = base32.encode(base64ToArrayBuffer(enctext));
|
||||
return res;
|
||||
return base32.encode(
|
||||
await encryptBuffer(Buffer.from(text), password, rounds)
|
||||
);
|
||||
};
|
||||
|
||||
export const decryptBase32ToString = (
|
||||
export const decryptBase32ToString = async (
|
||||
text: string,
|
||||
password: string,
|
||||
rounds: number = DEFAULT_ITER
|
||||
) => {
|
||||
const enc = Buffer.from(base32.decode.asBytes(text)).toString("base64");
|
||||
const wa = CryptoJS.enc.Base64.parse(enc);
|
||||
const dec = decryptWordArray(wa, password, rounds);
|
||||
const dectext = CryptoJS.enc.Utf8.stringify(dec);
|
||||
return dectext;
|
||||
return (
|
||||
await decryptBuffer(
|
||||
Buffer.from(base32.decode.asBytes(text)),
|
||||
password,
|
||||
rounds
|
||||
)
|
||||
).toString();
|
||||
};
|
||||
|
||||
@@ -109,7 +109,7 @@ export const uploadToRemote = async (
|
||||
const localContent = await vault.adapter.readBinary(fileOrFolderPath);
|
||||
let remoteContent = localContent;
|
||||
if (password !== "") {
|
||||
remoteContent = encryptArrayBuffer(localContent, password);
|
||||
remoteContent = await encryptArrayBuffer(localContent, password);
|
||||
}
|
||||
const body = arrayBufferToBuffer(remoteContent);
|
||||
await s3Client.send(
|
||||
@@ -214,7 +214,7 @@ export const downloadFromRemote = async (
|
||||
);
|
||||
let localContent = remoteContent;
|
||||
if (password !== "") {
|
||||
localContent = decryptArrayBuffer(remoteContent, password);
|
||||
localContent = await decryptArrayBuffer(remoteContent, password);
|
||||
}
|
||||
await vault.adapter.writeBinary(fileOrFolderPath, localContent, {
|
||||
mtime: mtime,
|
||||
|
||||
+2
-2
@@ -62,7 +62,7 @@ export const ensembleMixedStates = async (
|
||||
const remoteEncryptedKey = entry.Key;
|
||||
let key = remoteEncryptedKey;
|
||||
if (password !== "") {
|
||||
key = decryptBase32ToString(remoteEncryptedKey, password);
|
||||
key = await decryptBase32ToString(remoteEncryptedKey, password);
|
||||
}
|
||||
const backwardMapping = await getSyncMetaMappingByRemoteKeyS3(
|
||||
db,
|
||||
@@ -299,7 +299,7 @@ export const doActualSync = async (
|
||||
if (password !== "") {
|
||||
remoteEncryptedKey = state.remote_encrypted_key;
|
||||
if (remoteEncryptedKey === undefined || remoteEncryptedKey === "") {
|
||||
remoteEncryptedKey = encryptStringToBase32(key, password);
|
||||
remoteEncryptedKey = await encryptStringToBase32(key, password);
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
+1
-1
@@ -1,3 +1,3 @@
|
||||
{
|
||||
"0.0.3": "0.12.15"
|
||||
"0.0.5": "0.12.15"
|
||||
}
|
||||
|
||||
+12
-1
@@ -1,4 +1,5 @@
|
||||
const path = require("path");
|
||||
const webpack = require("webpack");
|
||||
const TerserPlugin = require("terser-webpack-plugin");
|
||||
|
||||
module.exports = {
|
||||
@@ -9,6 +10,16 @@ module.exports = {
|
||||
path: __dirname,
|
||||
libraryTarget: "commonjs",
|
||||
},
|
||||
plugins: [
|
||||
// Work around for Buffer is undefined:
|
||||
// https://github.com/webpack/changelog-v5/issues/10
|
||||
new webpack.ProvidePlugin({
|
||||
Buffer: ["buffer", "Buffer"],
|
||||
}),
|
||||
new webpack.ProvidePlugin({
|
||||
process: "process/browser",
|
||||
}),
|
||||
],
|
||||
module: {
|
||||
rules: [
|
||||
{
|
||||
@@ -20,7 +31,7 @@ module.exports = {
|
||||
},
|
||||
resolve: {
|
||||
extensions: [".tsx", ".ts", ".js"],
|
||||
mainFields: ["module", "main"],
|
||||
mainFields: ["browser", "module", "main"],
|
||||
fallback: {
|
||||
assert: require.resolve("assert"),
|
||||
buffer: require.resolve("buffer/"),
|
||||
|
||||
Reference in New Issue
Block a user