dany/antos-frontend
1
0
Fork 0
mirror of https://github.com/lxsang/antos-frontend.git synced 2025-02-22 09:52:47 +01:00
Code Issues 1 Actions Projects Releases Wiki Activity

Add more control to mem file + bug fix on File

Browse Source
This commit is contained in:
DanyLE 2022-07-02 21:36:07 +02:00
parent fdcc5ce784
commit f97a45be15
4 changed files with 196 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

41
d.ts/antos.d.ts vendored
View File

@ -9232,6 +9232,14 @@ declare namespace OS {
* @memberof BufferFileHandle * @memberof BufferFileHandle
*/ */
meta(): Promise<RequestResult>; meta(): Promise<RequestResult>;
/**
* Load the file meta-data before performing
* any task
*
* @returns {Promise<FileInfoType>} a promise on file meta-data
* @memberof BufferFileHandle
*/
onready(): Promise<FileInfoType>;
/** /**
* Read file content stored in the file cached * Read file content stored in the file cached
* *
@ -9246,11 +9254,40 @@ declare namespace OS {
* *
* @protected * @protected
* @param {string} t data type, see [[write]] * @param {string} t data type, see [[write]]
* @param {*} d data
* @returns {Promise<RequestResult>} * @returns {Promise<RequestResult>}
* @memberof BufferFileHandle * @memberof BufferFileHandle
*/ */
protected _wr(t: string, d: any): Promise<RequestResult>; protected _wr(t: string): Promise<RequestResult>;
/**
* Create sub directory
*
* Only work on directory file handle
*
* @protected
* @param {string} d sub directory name
* @returns {Promise<RequestResult>}
* @memberof BufferFileHandle
*/
protected _mk(d: string): Promise<RequestResult>;
/**
* Delete file/folder
*
* @protected
* @returns {Promise<RequestResult>}
* @memberof BufferFileHandle
*/
protected _rm(): Promise<RequestResult>;
setPath(p: string): void;
private updatePath;
/**
* Move file/folder
*
* @protected
* @param {string} d
* @returns {Promise<RequestResult>}
* @memberof BufferFileHandle
*/
protected _mv(d: string): Promise<RequestResult>;
/** /**
* Download the buffer file * Download the buffer file
* *

BIN
release/antos-1.2.1.tar.gz
View File

Binary file not shown.

166
src/core/vfs.ts
View File

@ -1459,14 +1459,14 @@ namespace OS {
constructor(path: string, mime: string, data: any) { constructor(path: string, mime: string, data: any) {
super(path); super(path);
this.info = { this.info = {
mime: mime, mime: mime?mime:'application/octet-stream',
path: path, path: path,
size: data ? data.length : 0, size: data ? data.length : 0,
name: this.basename, name: this.basename,
filename:this.basename, filename:this.basename,
ctime: (new Date()).toGMTString(), ctime: (new Date()).toGMTString(),
mtime: (new Date()).toGMTString(), mtime: (new Date()).toGMTString(),
type: undefined, type: 'file',
}; };
if (data) { if (data) {
this.cache = data; this.cache = data;
@ -1491,7 +1491,14 @@ namespace OS {
for(let i = 0;i<this.genealogy.length - 1;i++) for(let i = 0;i<this.genealogy.length - 1;i++)
{ {
const segment = this.genealogy[i]; const segment = this.genealogy[i];
let handle = curr_level.cache[segment]; let handle = undefined;
if(segment == "..")
{
curr_level = curr_level.parent();
continue;
}
handle = curr_level.cache[segment];
if(!handle) if(!handle)
{ {
handle = new BufferFileHandle(`${curr_level.path}/${segment}`, 'dir', {}); handle = new BufferFileHandle(`${curr_level.path}/${segment}`, 'dir', {});
@ -1503,6 +1510,10 @@ namespace OS {
curr_level.cache = {}; curr_level.cache = {};
} }
} }
if(this.basename == "..")
{
return curr_level.parent() as BufferFileHandle;
}
if(!curr_level.cache[this.basename]) if(!curr_level.cache[this.basename])
curr_level.cache[this.basename] = this; curr_level.cache[this.basename] = this;
return curr_level.cache[this.basename]; return curr_level.cache[this.basename];
@ -1517,13 +1528,23 @@ namespace OS {
{ {
return; return;
} }
this.info.mime = (new Date()).toGMTString();
if(typeof this.cache === "string" || this.cache instanceof Blob || this.cache instanceof Uint8Array) if(typeof this.cache === "string" || this.cache instanceof Blob || this.cache instanceof Uint8Array)
{ {
this.info.type = "file"; this.info.type = "file";
if(typeof this.cache === "string")
{
this.info.mime = "text/plain";
}
else
{
this.info.mime = "application/octet-stream";
}
} }
else else
{ {
this.info.type = "dir"; this.info.type = "dir";
this.info.mime = "dir";
} }
this.info.size = this.cache.length; this.info.size = this.cache.length;
} }
@ -1535,11 +1556,39 @@ namespace OS {
*/ */
meta(): Promise<RequestResult> { meta(): Promise<RequestResult> {
return new Promise((resolve, reject) => return new Promise((resolve, reject) =>
{
const data = {};
for(const k in this.info)
{
data[k] = this.info[k];
}
resolve({ resolve({
result: this.info, result: data,
error: false, error: false,
}) })
); });
}
/**
* Load the file meta-data before performing
* any task
*
* @returns {Promise<FileInfoType>} a promise on file meta-data
* @memberof BufferFileHandle
*/
onready(): Promise<FileInfoType> {
// read meta data
return new Promise(async (resolve, reject) => {
try
{
const d = await this.meta();
resolve(d.result as FileInfoType);
}
catch(e)
{
reject(__e(e));
}
});
} }
/** /**
@ -1568,12 +1617,10 @@ namespace OS {
* *
* @protected * @protected
* @param {string} t data type, see [[write]] * @param {string} t data type, see [[write]]
* @param {*} d data
* @returns {Promise<RequestResult>} * @returns {Promise<RequestResult>}
* @memberof BufferFileHandle * @memberof BufferFileHandle
*/ */
protected _wr(t: string, d: any): Promise<RequestResult> { protected _wr(t: string): Promise<RequestResult> {
this.cache = d;
return new Promise((resolve, reject) => return new Promise((resolve, reject) =>
resolve({ resolve({
result: true, result: true,
@ -1582,6 +1629,106 @@ namespace OS {
); );
} }
/**
* Create sub directory
*
* Only work on directory file handle
*
* @protected
* @param {string} d sub directory name
* @returns {Promise<RequestResult>}
* @memberof BufferFileHandle
*/
protected _mk(d: string): Promise<RequestResult> {
return new Promise((resolve, reject) => {
if (this.info.type === "file") {
return reject(
API.throwe(
__("{0} is not a directory", this.path)
)
);
}
const handle = `${this.path}/${d}`.asFileHandle();
if(handle.info.type === "file")
{
handle.cache = {};
}
resolve({result: true, error: false});
});
}
/**
* Delete file/folder
*
* @protected
* @returns {Promise<RequestResult>}
* @memberof BufferFileHandle
*/
protected _rm(): Promise<RequestResult> {
return new Promise(async (resolve, reject) => {
try {
const parent = this.parent();
parent.cache[this.basename] = undefined;
delete parent.cache[this.basename];
return resolve({result: true, error: false});
} catch (e) {
return reject(__e(e));
}
});
}
setPath(p: string): void
{
super.setPath(p);
if(this.info)
this.info.path = this.path;
}
private updatePath(path: string)
{
this.setPath(path);
if(this.info.type == "file")
{
return;
}
for(const k in this.cache)
{
const child = this.cache[k];
child.updatePath(`${this.path}/${child.basename}`);
}
}
/**
* Move file/folder
*
* @protected
* @param {string} d
* @returns {Promise<RequestResult>}
* @memberof BufferFileHandle
*/
protected _mv(d: string): Promise<RequestResult> {
return new Promise(async (resolve, reject) => {
try {
if(d.includes(this.path))
{
return reject(API.throwe(__("Unable to move file/folder from {0} to {1}", this.path, d)));
}
const parent = this.parent()
parent.cache[this.basename] = undefined;
delete parent.cache[this.basename];
const dest = d.asFileHandle();
this.updatePath(dest.path);
dest.parent().cache[dest.basename] = this;
return resolve({result: true, error: false});
} catch (e) {
console.log(this);
return reject(__e(e));
}
});
}
/** /**
* Download the buffer file * Download the buffer file
* *
@ -1924,11 +2071,11 @@ namespace OS {
promises.push(new Promise(async (resolve, reject) => { promises.push(new Promise(async (resolve, reject) => {
try { try {
const file = path.asFileHandle(); const file = path.asFileHandle();
const tof = `${to}/${file.basename}`.asFileHandle();
const meta = await file.onready(); const meta = await file.onready();
if (meta.type === "dir") { if (meta.type === "dir") {
const desdir = to.asFileHandle(); const desdir = to.asFileHandle();
await desdir.mk(file.basename); await desdir.mk(file.basename);
console.log(desdir, to);
const ret = await file.read(); const ret = await file.read();
const files = ret.result.map((v: API.FileInfoType) => v.path); const files = ret.result.map((v: API.FileInfoType) => v.path);
if (files.length > 0) { if (files.length > 0) {
@ -1940,6 +2087,7 @@ namespace OS {
} }
} }
else { else {
const tof = `${to}/${file.basename}`.asFileHandle();
const content = await file.read("binary"); const content = await file.read("binary");
await tof await tof
.setCache( .setCache(

6
src/packages/Files/main.ts
View File

@ -212,12 +212,6 @@ namespace OS {
if (d.error) { if (d.error) {
return reject(d.error); return reject(d.error);
} }
if (!dir.isRoot()) {
const p = dir.parent();
p.filename = "[..]";
p.type = "dir";
d.result.unshift(p);
}
this.currdir = dir; this.currdir = dir;
$(this.navinput).val(dir.path); $(this.navinput).val(dir.path);
(this.scheme as GUI.tag.WindowTag).apptitle = dir.path; (this.scheme as GUI.tag.WindowTag).apptitle = dir.path;