2017-11-03 02:09:34 +02:00
|
|
|
const { time } = require('lib/time-utils.js');
|
2017-12-18 22:47:25 +02:00
|
|
|
const fs = require('fs-extra');
|
2018-01-21 21:45:32 +02:00
|
|
|
const { basicDelta } = require('lib/file-api');
|
2017-06-18 01:49:52 +02:00
|
|
|
|
2017-06-13 22:12:08 +02:00
|
|
|
class FileApiDriverMemory {
|
2017-06-27 21:26:29 +02:00
|
|
|
constructor() {
|
2017-06-13 22:12:08 +02:00
|
|
|
this.items_ = [];
|
2017-07-18 22:03:07 +02:00
|
|
|
this.deletedItems_ = [];
|
2017-06-13 22:12:08 +02:00
|
|
|
}
|
|
|
|
|
2017-12-18 22:47:25 +02:00
|
|
|
encodeContent_(content) {
|
|
|
|
if (content instanceof Buffer) {
|
|
|
|
return content.toString('base64');
|
|
|
|
} else {
|
|
|
|
return Buffer.from(content).toString('base64');
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
decodeContent_(content) {
|
2018-02-15 19:12:09 +02:00
|
|
|
return Buffer.from(content, 'base64').toString('utf-8');
|
2017-12-18 22:47:25 +02:00
|
|
|
}
|
|
|
|
|
2017-06-13 22:12:08 +02:00
|
|
|
itemIndexByPath(path) {
|
|
|
|
for (let i = 0; i < this.items_.length; i++) {
|
|
|
|
if (this.items_[i].path == path) return i;
|
|
|
|
}
|
|
|
|
return -1;
|
|
|
|
}
|
|
|
|
|
|
|
|
itemByPath(path) {
|
|
|
|
let index = this.itemIndexByPath(path);
|
|
|
|
return index < 0 ? null : this.items_[index];
|
|
|
|
}
|
|
|
|
|
|
|
|
newItem(path, isDir = false) {
|
2017-06-19 00:06:10 +02:00
|
|
|
let now = time.unixMs();
|
2017-06-13 22:12:08 +02:00
|
|
|
return {
|
|
|
|
path: path,
|
|
|
|
isDir: isDir,
|
2017-06-19 00:06:10 +02:00
|
|
|
updated_time: now, // In milliseconds!!
|
2018-02-07 22:42:52 +02:00
|
|
|
// created_time: now, // In milliseconds!!
|
2017-06-13 22:12:08 +02:00
|
|
|
content: '',
|
|
|
|
};
|
|
|
|
}
|
|
|
|
|
|
|
|
stat(path) {
|
2017-06-18 01:49:52 +02:00
|
|
|
let item = this.itemByPath(path);
|
|
|
|
return Promise.resolve(item ? Object.assign({}, item) : null);
|
2017-06-13 22:12:08 +02:00
|
|
|
}
|
|
|
|
|
2018-02-15 19:12:09 +02:00
|
|
|
async setTimestamp(path, timestampMs) {
|
2017-06-18 01:49:52 +02:00
|
|
|
let item = this.itemByPath(path);
|
2017-06-13 22:12:08 +02:00
|
|
|
if (!item) return Promise.reject(new Error('File not found: ' + path));
|
2017-06-27 21:48:01 +02:00
|
|
|
item.updated_time = timestampMs;
|
2017-06-13 22:12:08 +02:00
|
|
|
}
|
|
|
|
|
2018-02-15 19:12:09 +02:00
|
|
|
async list(path, options) {
|
2017-06-13 22:12:08 +02:00
|
|
|
let output = [];
|
|
|
|
|
|
|
|
for (let i = 0; i < this.items_.length; i++) {
|
|
|
|
let item = this.items_[i];
|
|
|
|
if (item.path == path) continue;
|
|
|
|
if (item.path.indexOf(path + '/') === 0) {
|
|
|
|
let s = item.path.substr(path.length + 1);
|
|
|
|
if (s.split('/').length === 1) {
|
|
|
|
let it = Object.assign({}, item);
|
2017-06-23 21:09:49 +02:00
|
|
|
it.path = it.path.substr(path.length + 1);
|
2017-06-13 22:12:08 +02:00
|
|
|
output.push(it);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2017-06-29 20:03:16 +02:00
|
|
|
return Promise.resolve({
|
|
|
|
items: output,
|
|
|
|
hasMore: false,
|
|
|
|
context: null,
|
|
|
|
});
|
2017-06-13 22:12:08 +02:00
|
|
|
}
|
|
|
|
|
2017-12-18 22:47:25 +02:00
|
|
|
async get(path, options) {
|
2017-06-13 22:12:08 +02:00
|
|
|
let item = this.itemByPath(path);
|
2017-06-18 01:49:52 +02:00
|
|
|
if (!item) return Promise.resolve(null);
|
2017-06-13 22:12:08 +02:00
|
|
|
if (item.isDir) return Promise.reject(new Error(path + ' is a directory, not a file'));
|
2017-12-18 22:47:25 +02:00
|
|
|
|
|
|
|
let output = null;
|
|
|
|
if (options.target === 'file') {
|
|
|
|
await fs.writeFile(options.path, Buffer.from(item.content, 'base64'));
|
|
|
|
} else {
|
|
|
|
const content = this.decodeContent_(item.content);
|
|
|
|
output = Promise.resolve(content);
|
|
|
|
}
|
|
|
|
|
|
|
|
return output;
|
2017-06-13 22:12:08 +02:00
|
|
|
}
|
|
|
|
|
2018-02-15 19:12:09 +02:00
|
|
|
async mkdir(path) {
|
2017-06-13 22:12:08 +02:00
|
|
|
let index = this.itemIndexByPath(path);
|
2018-02-15 19:12:09 +02:00
|
|
|
if (index >= 0) return;
|
2017-06-13 22:12:08 +02:00
|
|
|
this.items_.push(this.newItem(path, true));
|
|
|
|
}
|
|
|
|
|
2017-12-18 22:47:25 +02:00
|
|
|
async put(path, content, options = null) {
|
|
|
|
if (!options) options = {};
|
|
|
|
|
|
|
|
if (options.source === 'file') content = await fs.readFile(options.path);
|
|
|
|
|
2017-06-13 22:12:08 +02:00
|
|
|
let index = this.itemIndexByPath(path);
|
|
|
|
if (index < 0) {
|
|
|
|
let item = this.newItem(path, false);
|
2017-12-18 22:47:25 +02:00
|
|
|
item.content = this.encodeContent_(content);
|
2017-06-13 22:12:08 +02:00
|
|
|
this.items_.push(item);
|
|
|
|
} else {
|
2017-12-18 22:47:25 +02:00
|
|
|
this.items_[index].content = this.encodeContent_(content);
|
2017-06-19 00:06:10 +02:00
|
|
|
this.items_[index].updated_time = time.unix();
|
2017-06-13 22:12:08 +02:00
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2018-02-15 19:12:09 +02:00
|
|
|
async delete(path) {
|
2017-06-13 22:12:08 +02:00
|
|
|
let index = this.itemIndexByPath(path);
|
|
|
|
if (index >= 0) {
|
2017-07-18 22:03:07 +02:00
|
|
|
let item = Object.assign({}, this.items_[index]);
|
|
|
|
item.isDeleted = true;
|
|
|
|
item.updated_time = time.unixMs();
|
|
|
|
this.deletedItems_.push(item);
|
2017-06-13 22:12:08 +02:00
|
|
|
this.items_.splice(index, 1);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2018-02-15 19:12:09 +02:00
|
|
|
async move(oldPath, newPath) {
|
2017-06-13 22:12:08 +02:00
|
|
|
let sourceItem = this.itemByPath(oldPath);
|
|
|
|
if (!sourceItem) return Promise.reject(new Error('Path not found: ' + oldPath));
|
|
|
|
this.delete(newPath); // Overwrite if newPath already exists
|
|
|
|
sourceItem.path = newPath;
|
|
|
|
}
|
|
|
|
|
2018-02-15 19:12:09 +02:00
|
|
|
async format() {
|
2017-06-13 22:58:17 +02:00
|
|
|
this.items_ = [];
|
|
|
|
}
|
|
|
|
|
2017-07-18 22:03:07 +02:00
|
|
|
async delta(path, options = null) {
|
2019-07-29 15:43:53 +02:00
|
|
|
const getStatFn = async path => {
|
2018-01-21 21:45:32 +02:00
|
|
|
let output = this.items_.slice();
|
|
|
|
for (let i = 0; i < output.length; i++) {
|
|
|
|
const item = Object.assign({}, output[i]);
|
2017-07-18 22:03:07 +02:00
|
|
|
item.path = item.path.substr(path.length + 1);
|
2018-01-21 21:45:32 +02:00
|
|
|
output[i] = item;
|
2017-07-18 22:03:07 +02:00
|
|
|
}
|
2018-01-21 21:45:32 +02:00
|
|
|
return output;
|
|
|
|
};
|
2017-07-18 22:03:07 +02:00
|
|
|
|
2018-01-21 21:45:32 +02:00
|
|
|
const output = await basicDelta(path, getStatFn, options);
|
2017-07-18 22:03:07 +02:00
|
|
|
return output;
|
|
|
|
}
|
|
|
|
|
2018-02-15 19:12:09 +02:00
|
|
|
async clearRoot() {
|
2018-01-25 23:15:58 +02:00
|
|
|
this.items_ = [];
|
|
|
|
}
|
2017-06-13 22:12:08 +02:00
|
|
|
}
|
|
|
|
|
2019-07-29 15:43:53 +02:00
|
|
|
module.exports = { FileApiDriverMemory };
|