use webkit file uploading to allow directories

This commit is contained in:
joshuaboud 2021-07-16 16:50:05 -03:00
parent 913461feee
commit 7d6490cd15
No known key found for this signature in database
GPG Key ID: 17EFB59E2A8BF50E
1 changed files with 114 additions and 58 deletions

View File

@ -18,6 +18,7 @@
*/ */
import {FileUpload} from "./FileUpload.js"; import {FileUpload} from "./FileUpload.js";
import { ModalPrompt } from "./ModalPrompt.js";
import {NavWindow} from "./NavWindow.js"; import {NavWindow} from "./NavWindow.js";
export class NavDragDrop { export class NavDragDrop {
@ -33,82 +34,137 @@ export class NavDragDrop {
drop_area.addEventListener("drop", this, false); drop_area.addEventListener("drop", this, false);
this.drop_area = drop_area; this.drop_area = drop_area;
this.nav_window_ref = nav_window_ref; this.nav_window_ref = nav_window_ref;
this.modal_prompt = new ModalPrompt();
} }
/**
*
* @param {FileSystemEntry} item
* @param {string} path
* @returns {Promise<FileUpload[]>}
*/
async scan_files(item, path) {
let new_uploads = [];
if (item.isDirectory) {
if (!path && !await this.modal_prompt.confirm(`Copy whole directory: ${item.fullPath}?`, "", true))
return new_uploads;
let directoryReader = item.createReader();
let promise = new Promise((resolve, reject) => {
directoryReader.readEntries(async (entries) => {
for (const entry of entries) {
new_uploads.push(... await this.scan_files(entry, path + item.name + "/"));
}
resolve();
});
})
await promise;
} else {
let promise = new Promise((resolve, reject) => {
item.file((file) => {
resolve(file);
})
});
new_uploads.push(new FileUpload(await promise, this.nav_window_ref, path));
}
return new_uploads;
}
/**
*
* @param {DataTransferItemList} items
* @returns {Promise<DataTransferItemList>}
*/
handle_drop_advanced(items) {
return new Promise(async (resolve, reject) => {
let uploads = [];
for (let i = 0; i < items.length; i++) {
let item = items[i]?.webkitGetAsEntry?.() ?? items[i]?.getAsEntry?.() ?? null;
let path = "";
if (item) {
let new_uploads = await this.scan_files(item, path);
console.log(new_uploads);
uploads.push(... new_uploads);
} else {
reject();
}
}
resolve(uploads);
})
}
/**
*
* @param {FileUpload[]} uploads
* @returns {FileUpload[]}
*/
async handle_conflicts(uploads) {
let keepers = [];
let requests = {};
for (let upload of uploads) {
if (!await upload.check_if_exists()) {
keepers.push(upload.filename);
continue;
}
let request = {};
request.label = upload.filename;
request.type = "checkbox";
let id = upload.filename;
requests[id] = request;
}
if (Object.keys(requests).length > 0) {
let responses = await this.nav_window_ref.modal_prompt.prompt(
"Conflicts found while uploading. Replace?",
requests
)
if (responses === null)
return null;
for (let key of Object.keys(responses)) {
if (responses[key])
keepers.push(key);
}
}
return uploads.filter((upload) => keepers.includes(upload.filename));
}
/**
*
* @param {Event} e
*/
async handleEvent(e) { async handleEvent(e) {
e.preventDefault();
e.stopPropagation();
switch(e.type){ switch(e.type){
case "dragenter": case "dragenter":
e.preventDefault();
e.stopPropagation();
this.drop_area.classList.add("drag-enter"); this.drop_area.classList.add("drag-enter");
break; break;
case "dragover": case "dragover":
e.preventDefault();
e.stopPropagation();
break; break;
case "dragleave": case "dragleave":
e.preventDefault();
e.stopPropagation();
this.drop_area.classList.remove("drag-enter"); this.drop_area.classList.remove("drag-enter");
break; break;
case "drop": case "drop":
let uploads = []; let uploads;
// console.log(e); let items = e.dataTransfer.items;
// console.log(e.dataTransfer.files); e.preventDefault();
// if (e.dataTransfer.items) { e.stopPropagation();
// for (let item of e.dataTransfer.items) { try {
// if (item.kind === 'file') { uploads = await this.handle_drop_advanced(items);
// var file = item.getAsFile(); } catch {
// if (file.type === "" && file.size !== 0) { uploads = [];
// await this.nav_window_ref.modal_prompt.alert(file.name + ": Cannot upload folders.");
// continue;
// }
// if (file.size === 0) {
// var proc = cockpit.spawn(
// ["/usr/share/cockpit/navigator/scripts/touch.py3", this.nav_window_ref.pwd().path_str() + "/" + file.name],
// {superuser: "try", err: "out"}
// );
// proc.done(() => {
// this.nav_window_ref.refresh();
// });
// } else {
// uploads.push(new FileUpload(file, this.nav_window_ref));
// }
// }
// }
// } else {
for (let file of e.dataTransfer.files) { for (let file of e.dataTransfer.files) {
console.log(file); let uploader = new FileUpload(file, this.nav_window_ref);
// if (file.type === "") uploader.using_webkit = false;
// continue; uploads.push(uploader);
uploads.push(new FileUpload(file, this.nav_window_ref));
} }
// } }
this.drop_area.classList.remove("drag-enter"); this.drop_area.classList.remove("drag-enter");
if (uploads.length === 0) if (uploads.length === 0)
break; break;
let keepers = []; uploads = await this.handle_conflicts(uploads);
let requests = {};
for (let upload of uploads) {
if (!await upload.check_if_exists()) {
keepers.push(upload.filename);
continue;
}
let request = {};
request.label = upload.filename;
request.type = "checkbox";
let id = upload.filename;
requests[id] = request;
}
if (Object.keys(requests).length > 0) {
let responses = await this.nav_window_ref.modal_prompt.prompt(
"Conflicts found while uploading. Replace?",
requests
)
if (responses === null)
break;
for (let key of Object.keys(responses)) {
if (responses[key])
keepers.push(key);
}
}
uploads = uploads.filter((upload) => {return keepers.includes(upload.filename)});
uploads.forEach((upload) => {upload.upload()}); uploads.forEach((upload) => {upload.upload()});
break; break;
default: default: