forked from hibas123/SecureFileWrapper
141 lines
4.2 KiB
JavaScript
141 lines
4.2 KiB
JavaScript
"use strict";
|
|
Object.defineProperty(exports, "__esModule", { value: true });
|
|
const rsa = require("node-rsa");
|
|
require("isomorphic-fetch");
|
|
const btb = require("blob-to-buffer");
|
|
class SecureFile {
|
|
constructor(server, username, private_key) {
|
|
this.Server = server;
|
|
if (this.Server.endsWith("/")) {
|
|
this.Server += "api";
|
|
}
|
|
else {
|
|
this.Server += "/api";
|
|
}
|
|
this.Username = username;
|
|
this.PrivateKey = private_key;
|
|
}
|
|
async getCode() {
|
|
let code_res = await fetch(this.Server + "/code?username=" + this.Username);
|
|
//ToDo check status Codes
|
|
let code = (await code_res.json()).code;
|
|
let r = new rsa(this.PrivateKey, "pkcs1-pem");
|
|
return { code: code, signature: r.sign(code).toString("base64") };
|
|
}
|
|
async makeRequest(endpoint, method, query, body) {
|
|
let code = await this.getCode();
|
|
query.code = code.code;
|
|
query.signature = code.signature;
|
|
let query_str = "?";
|
|
let first = true;
|
|
for (let key in query) {
|
|
if (!first)
|
|
query_str += "&";
|
|
query_str += encodeURIComponent(key) + "=" + encodeURIComponent(query[key]);
|
|
first = false;
|
|
}
|
|
return await fetch(this.Server + endpoint + query_str, { method: method, body: body });
|
|
}
|
|
async test() {
|
|
let res = await this.makeRequest("/test", "GET", {}, undefined);
|
|
statusParser(res);
|
|
return await res.json();
|
|
}
|
|
async list(folder) {
|
|
if (!folder)
|
|
folder = "root";
|
|
let res = await this.makeRequest("/files", "GET", { folder: folder }, undefined);
|
|
statusParser(res);
|
|
return await res.json();
|
|
}
|
|
async create(name, data, type, folder, encrypt = true, preview) {
|
|
let params = { type: type, name: name, no_encryption: !encrypt };
|
|
if (preview) {
|
|
params.preview = preview;
|
|
}
|
|
if (folder) {
|
|
params.folder = folder;
|
|
}
|
|
if (!encrypt) {
|
|
params.no_encryption = true;
|
|
}
|
|
let res = await this.makeRequest("/files", "POST", params, data);
|
|
statusParser(res);
|
|
return res.json();
|
|
}
|
|
async get(id, version) {
|
|
let res;
|
|
if (typeof version === "string") {
|
|
res = await this.makeRequest(`/files/${id}/history/${version}`, "GET", {}, undefined);
|
|
}
|
|
else {
|
|
res = await this.makeRequest("/files/" + id, "GET", {}, undefined);
|
|
}
|
|
statusParser(res);
|
|
if (res.buffer) {
|
|
return res.buffer();
|
|
}
|
|
else {
|
|
return new Promise(async (resolve, reject) => {
|
|
btb(await res.blob(), (err, buffer) => {
|
|
if (err)
|
|
reject(err);
|
|
else
|
|
resolve(buffer);
|
|
});
|
|
});
|
|
}
|
|
}
|
|
async update(id, data, preview) {
|
|
let put = {};
|
|
if (preview)
|
|
put.preview = preview;
|
|
let res = await this.makeRequest("/files/" + id, "PUT", put, data);
|
|
statusParser(res);
|
|
return res.json();
|
|
}
|
|
async delete(id) {
|
|
let res = await this.makeRequest("/files/" + id, "DELETE", {}, undefined);
|
|
statusParser(res);
|
|
return res.json();
|
|
}
|
|
async history(id) {
|
|
let res = await this.makeRequest(`/files/${id}/history`, "GET", {}, undefined);
|
|
statusParser(res);
|
|
return res.json();
|
|
}
|
|
}
|
|
exports.default = SecureFile;
|
|
class Unauthorized extends Error {
|
|
constructor() {
|
|
super("Not authorized");
|
|
}
|
|
}
|
|
exports.Unauthorized = Unauthorized;
|
|
class NotFound extends Error {
|
|
constructor() {
|
|
super("Not found");
|
|
}
|
|
}
|
|
exports.NotFound = NotFound;
|
|
class BadRequest extends Error {
|
|
constructor() {
|
|
super("Bad request");
|
|
}
|
|
}
|
|
exports.BadRequest = BadRequest;
|
|
function statusParser(res) {
|
|
if (res.status !== 200) {
|
|
switch (res.status) {
|
|
case 400:
|
|
throw new BadRequest();
|
|
case 404:
|
|
throw new NotFound();
|
|
case 403:
|
|
throw new Unauthorized();
|
|
default:
|
|
throw new Error(res.statusText);
|
|
}
|
|
}
|
|
}
|