117 lines
3.8 KiB
JavaScript
117 lines
3.8 KiB
JavaScript
window.moonCoreFileManager = {
|
|
uploadCache: [],
|
|
readCache: async function (index) {
|
|
const item = this.uploadCache.at(index);
|
|
const streamRef = await this.createStreamRef(item);
|
|
|
|
return {
|
|
path: item.fullPath,
|
|
streamRef: streamRef
|
|
};
|
|
},
|
|
createStreamRef: async function (fileEntry) {
|
|
const promise = new Promise(resolve => {
|
|
fileEntry.file(file => {
|
|
resolve(file);
|
|
}, err => console.log(err));
|
|
});
|
|
|
|
const processedFile = await promise;
|
|
|
|
// Prevent uploads of empty files
|
|
if (processedFile.size <= 0) {
|
|
console.log("Skipping upload of '" + fileEntry.fullPath + "' as its empty");
|
|
return null;
|
|
}
|
|
|
|
const fileReader = new FileReader();
|
|
|
|
const readerPromise = new Promise(resolve => {
|
|
fileReader.addEventListener("loadend", ev => {
|
|
resolve(fileReader.result)
|
|
});
|
|
});
|
|
|
|
fileReader.readAsArrayBuffer(processedFile);
|
|
|
|
const arrayBuffer = await readerPromise;
|
|
|
|
return DotNet.createJSStreamReference(arrayBuffer);
|
|
},
|
|
setup: function (id, callbackRef) {
|
|
// Check which features are supported by the browser
|
|
const supportsFileSystemAccessAPI =
|
|
'getAsFileSystemHandle' in DataTransferItem.prototype;
|
|
const supportsWebkitGetAsEntry =
|
|
'webkitGetAsEntry' in DataTransferItem.prototype;
|
|
|
|
// This is the drag and drop zone.
|
|
const elem = document.getElementById(id);
|
|
|
|
// Prevent navigation.
|
|
elem.addEventListener('dragover', (e) => {
|
|
e.preventDefault();
|
|
});
|
|
|
|
elem.addEventListener('drop', async (e) => {
|
|
// Prevent navigation.
|
|
e.preventDefault();
|
|
|
|
if (!supportsFileSystemAccessAPI && !supportsWebkitGetAsEntry) {
|
|
// Cannot handle directories.
|
|
console.log("Cannot handle directories");
|
|
return;
|
|
}
|
|
|
|
this.getAllWebkitFileEntries(e.dataTransfer.items).then(async value => {
|
|
this.uploadCache = value;
|
|
await callbackRef.invokeMethodAsync("OnFilesDropped", this.uploadCache.length);
|
|
});
|
|
});
|
|
},
|
|
getAllWebkitFileEntries: async function (dataTransferItemList) {
|
|
function readAllEntries(reader) {
|
|
return new Promise((resolve, reject) => {
|
|
const entries = [];
|
|
function readEntries() {
|
|
reader.readEntries((batch) => {
|
|
if (batch.length === 0) {
|
|
resolve(entries);
|
|
} else {
|
|
entries.push(...batch);
|
|
readEntries();
|
|
}
|
|
}, reject);
|
|
}
|
|
readEntries();
|
|
});
|
|
}
|
|
|
|
async function traverseEntry(entry) {
|
|
if (entry.isFile) {
|
|
return [entry];
|
|
} else if (entry.isDirectory) {
|
|
const reader = entry.createReader();
|
|
const entries = await readAllEntries(reader);
|
|
const subEntries = await Promise.all(entries.map(traverseEntry));
|
|
return subEntries.flat();
|
|
}
|
|
return [];
|
|
}
|
|
|
|
const entries = [];
|
|
|
|
// Convert DataTransferItemList to entries
|
|
for (let i = 0; i < dataTransferItemList.length; i++) {
|
|
const item = dataTransferItemList[i];
|
|
const entry = item.webkitGetAsEntry();
|
|
if (entry) {
|
|
entries.push(entry);
|
|
}
|
|
}
|
|
|
|
// Traverse all entries and collect file entries
|
|
const allFileEntries = await Promise.all(entries.map(traverseEntry));
|
|
return allFileEntries.flat();
|
|
}
|
|
} |