mirrors/puter
1
0
Fork 0
mirror of https://github.com/HeyPuter/puter synced 2024-11-14 22:06:00 +00:00
Code Issues Packages Projects Releases Wiki Activity

offloaded write operations to Upload module

Browse Source
This commit is contained in:
4nshuman 2024-10-20 00:06:30 +05:30
parent f32b1cfce8
commit 4fdea7db66
1 changed files with 26 additions and 30 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

56
src/gui/src/helpers.js
View File

@ -2203,39 +2203,35 @@ window.unzipItem = async function(itemPath) {
}, Math.max(0, window.copy_progress_hide_delay - (Date.now() - start_ts)));
} else {
const rootdir = await puter.fs.mkdir(path.dirname(filePath) + '/' + path.basename(filePath, '.zip'), { dedupeName: true });
let queuedFileWrites = []
let perItemProgress = window.zippingProgressConfig.WRITING / Object.keys(unzipped).length;
let queuedFileWrites = []
Object.keys(unzipped).forEach(fileItem => {
let fileWriteProcess = new Promise(async (resolve, reject) => {
try {
let dirLevel, fileName;
let fileData = new Blob([new Uint8Array(unzipped[fileItem], unzipped[fileItem].byteOffset, unzipped[fileItem].length)]);
if (fileItem.includes("/")) {
[dirLevel, fileName] = [fileItem.slice(0, fileItem.lastIndexOf("/")), fileItem.slice(fileItem.lastIndexOf("/") + 1)]
await puter.fs.mkdir(rootdir.path + '/' + dirLevel, { createMissingParents: true });
} else {
fileName = fileItem;
}
progwin?.set_status(i18n('writing', fileItem));
fileName != "" && await puter.fs.write(rootdir.path + '/' + fileItem, fileData);
currentProgress += perItemProgress;
progwin?.set_progress(currentProgress.toPrecision(2));
resolve();
} catch (e) {
UIAlert(e.message);
reject();
}
})
queuedFileWrites.push(fileWriteProcess);
});
Promise.all(queuedFileWrites).then(() => {
progwin?.set_progress(window.zippingProgressConfig.TOTAL.toPrecision(2));
// close progress window
clearTimeout(progwin_timeout);
setTimeout(() => {
progwin?.close();
}, Math.max(0, window.unzip_progress_hide_delay - (Date.now() - start_ts)));
try {
let fileData = new Blob([new Uint8Array(unzipped[fileItem], unzipped[fileItem].byteOffset, unzipped[fileItem].length)]);
progwin?.set_status(i18n('writing', fileItem));
queuedFileWrites.push(new File([fileData], fileItem))
currentProgress += perItemProgress;
progwin?.set_progress(currentProgress.toPrecision(2));
} catch (e) {
UIAlert(e.message);
}
});
queuedFileWrites.length && puter.fs.upload(
// what to upload
queuedFileWrites,
// where to upload
rootdir.path + '/',
// options
{
createFileParent: true
}
);
progwin?.set_progress(window.zippingProgressConfig.TOTAL.toPrecision(2));
// close progress window
clearTimeout(progwin_timeout);
setTimeout(() => {
progwin?.close();
}, Math.max(0, window.unzip_progress_hide_delay - (Date.now() - start_ts)));
}
});
}