mirror of
https://gitlab.com/crafty-controller/crafty-4.git
synced 2024-08-30 18:23:09 +00:00
208 lines
7.9 KiB
JavaScript
208 lines
7.9 KiB
JavaScript
async function uploadFile(type, file = null, path = null, file_num = 0, _onProgress = null) {
|
|
if (file == null) {
|
|
try {
|
|
file = $("#file")[0].files[0];
|
|
} catch {
|
|
bootbox.alert("Please select a file first.")
|
|
return;
|
|
}
|
|
|
|
}
|
|
const fileId = uuidv4();
|
|
const token = getCookie("_xsrf");
|
|
if (type !== "server_upload") {
|
|
document.getElementById("upload_input").innerHTML = '<div class="progress" style="width: 100%;"><div id="upload-progress-bar" class="progress-bar progress-bar-striped progress-bar-animated" role="progressbar" aria-valuenow="100" aria-valuemin="0" aria-valuemax="100" style="width: 100%"> <i class="fa-solid fa-spinner"></i></div></div>';
|
|
}
|
|
|
|
let url = ``
|
|
if (type === "server_upload") {
|
|
url = `/api/v2/servers/${serverId}/files/upload/`;
|
|
} else if (type === "background") {
|
|
url = `/api/v2/crafty/admin/upload/`
|
|
} else if (type === "import") {
|
|
url = `/api/v2/servers/import/upload/`
|
|
}
|
|
console.log(url)
|
|
const chunkSize = 1024 * 1024 * 10; // 10MB
|
|
const totalChunks = Math.ceil(file.size / chunkSize);
|
|
|
|
const uploadPromises = [];
|
|
let errors = []; // Array to store errors
|
|
try {
|
|
let res = await fetch(url, {
|
|
method: 'POST',
|
|
headers: {
|
|
'X-XSRFToken': token,
|
|
'chunked': true,
|
|
'fileSize': file.size,
|
|
'type': type,
|
|
'totalChunks': totalChunks,
|
|
'fileName': file.name,
|
|
'location': path,
|
|
'fileId': fileId,
|
|
},
|
|
body: null,
|
|
});
|
|
|
|
if (!res.ok) {
|
|
let errorResponse = await res.json();
|
|
throw new Error(JSON.stringify(errorResponse));
|
|
}
|
|
|
|
let responseData = await res.json();
|
|
|
|
if (responseData.status !== "ok") {
|
|
throw new Error(JSON.stringify(responseData));
|
|
}
|
|
|
|
for (let i = 0; i < totalChunks; i++) {
|
|
const start = i * chunkSize;
|
|
const end = Math.min(start + chunkSize, file.size);
|
|
const chunk = file.slice(start, end);
|
|
const chunk_hash = await calculateFileHash(chunk);
|
|
|
|
const uploadPromise = fetch(url, {
|
|
method: 'POST',
|
|
body: chunk,
|
|
headers: {
|
|
'Content-Range': `bytes ${start}-${end - 1}/${file.size}`,
|
|
'Content-Length': chunk.size,
|
|
'fileSize': file.size,
|
|
'chunkHash': chunk_hash,
|
|
'chunked': true,
|
|
'type': type,
|
|
'totalChunks': totalChunks,
|
|
'fileName': file.name,
|
|
'location': path,
|
|
'fileId': fileId,
|
|
'chunkId': i,
|
|
},
|
|
})
|
|
.then(async response => {
|
|
if (!response.ok) {
|
|
const errorData = await response.json();
|
|
throw new Error(JSON.stringify(errorData) || 'Unknown error occurred');
|
|
}
|
|
return response.json(); // Return the JSON data
|
|
})
|
|
.then(data => {
|
|
if (data.status !== "completed" && data.status !== "partial") {
|
|
throw new Error(data.message || 'Unknown error occurred');
|
|
}
|
|
// Update progress bar
|
|
const progress = (i + 1) / totalChunks * 100;
|
|
updateProgressBar(Math.round(progress), type, file_num);
|
|
})
|
|
.catch(error => {
|
|
errors.push(error); // Store the error
|
|
});
|
|
|
|
uploadPromises.push(uploadPromise);
|
|
}
|
|
|
|
await Promise.all(uploadPromises);
|
|
} catch (error) {
|
|
errors.push(error); // Store the error
|
|
}
|
|
|
|
if (errors.length > 0) {
|
|
const errorMessage = errors.map(error => JSON.parse(error.message).data.message || 'Unknown error occurred').join('<br>');
|
|
console.log(errorMessage)
|
|
bootbox.alert({
|
|
title: 'Error',
|
|
message: errorMessage,
|
|
callback: function () {
|
|
window.location.reload();
|
|
},
|
|
});
|
|
} else if (type !== "server_upload") {
|
|
// All promises resolved successfully
|
|
$("#upload_input").html(`<div class="card-header header-sm d-flex justify-content-between align-items-center" style="width: 100%;"><input value="${file.name}" type="text" id="file-uploaded" disabled></input> 🔒</div>`);
|
|
if (type === "import") {
|
|
document.getElementById("lower_half").style.visibility = "visible";
|
|
document.getElementById("lower_half").hidden = false;
|
|
} else if (type === "background") {
|
|
setTimeout(function () {
|
|
location.href = `/panel/custom_login`;
|
|
}, 2000);
|
|
}
|
|
} else {
|
|
let caught = false;
|
|
let expanded = false;
|
|
try {
|
|
expanded = document.getElementById(path).classList.contains("clicked");
|
|
} catch { }
|
|
|
|
let par_el;
|
|
let items;
|
|
try {
|
|
par_el = document.getElementById(path + "ul");
|
|
items = par_el.children;
|
|
} catch (err) {
|
|
console.log(err);
|
|
caught = true;
|
|
par_el = document.getElementById("files-tree");
|
|
items = par_el.children;
|
|
}
|
|
|
|
let name = file.name;
|
|
let full_path = path + '/' + name;
|
|
let flag = false;
|
|
|
|
for (let item of items) {
|
|
if ($(item).attr("data-name") === name) {
|
|
flag = true;
|
|
}
|
|
}
|
|
|
|
if (!flag) {
|
|
if (caught && !expanded) {
|
|
$(par_el).append(`<li id="${full_path}li" class="d-block tree-ctx-item tree-file tree-item" data-path="${full_path}" data-name="${name}" onclick="clickOnFile(event)"><span style="margin-right: 6px;"><i class="far fa-file"></i></span>${name}</li>`);
|
|
} else if (expanded) {
|
|
$(par_el).append(`<li id="${full_path}li" class="tree-ctx-item tree-file tree-item" data-path="${full_path}" data-name="${name}" onclick="clickOnFile(event)"><span style="margin-right: 6px;"><i class="far fa-file"></i></span>${name}</li>`);
|
|
}
|
|
setTreeViewContext();
|
|
}
|
|
|
|
$(`#upload-progress-bar-${file_num + 1}`).removeClass("progress-bar-striped");
|
|
$(`#upload-progress-bar-${file_num + 1}`).addClass("bg-success");
|
|
$(`#upload-progress-bar-${file_num + 1}`).html('<i style="color: black;" class="fas fa-box-check"></i>');
|
|
}
|
|
}
|
|
|
|
async function calculateFileHash(file) {
|
|
const arrayBuffer = await file.arrayBuffer();
|
|
const hashBuffer = await crypto.subtle.digest('SHA-256', arrayBuffer);
|
|
const hashArray = Array.from(new Uint8Array(hashBuffer));
|
|
const hashHex = hashArray.map(b => b.toString(16).padStart(2, '0')).join('');
|
|
|
|
return hashHex;
|
|
}
|
|
|
|
function updateProgressBar(progress, type, i) {
|
|
if (type !== "server_upload") {
|
|
if (progress === 100) {
|
|
$(`#upload-progress-bar`).removeClass("progress-bar-striped")
|
|
|
|
$(`#upload-progress-bar`).removeClass("progress-bar-animated")
|
|
}
|
|
$(`#upload-progress-bar`).css('width', progress + '%');
|
|
$(`#upload-progress-bar`).html(progress + '%');
|
|
} else {
|
|
if (progress === 100) {
|
|
$(`#upload-progress-bar-${i + 1}`).removeClass("progress-bar-striped")
|
|
|
|
$(`#upload-progress-bar-${i + 1}`).removeClass("progress-bar-animated")
|
|
}
|
|
$(`#upload-progress-bar-${i + 1}`).css('width', progress + '%');
|
|
$(`#upload-progress-bar-${i + 1}`).html(progress + '%');
|
|
}
|
|
}
|
|
|
|
function uuidv4() {
|
|
return 'xxxxxxxx-xxxx-4xxx-yxxx-xxxxxxxxxxxx'.replace(/[xy]/g, function (c) {
|
|
const r = Math.random() * 16 | 0,
|
|
v = c === 'x' ? r : (r & 0x3 | 0x8);
|
|
return v.toString(16);
|
|
});
|
|
} |