mincomk/risuai
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix: backup size limit (#702)

Browse Source 
## Issue track
Previously, the backup loading was depending on ArrayBuffer. In chromium
based browsers, ArrayBuffer's size is limited to 2GB, and anything more
will fail to read the data.

This affects Tauri too, as Tauri uses Edge webview2 which also is based
on chromium.

The proposed change uses file stream instead of ArrayBuffer, effectively
ignoring forced file size limit of 2GB.

# PR Checklist
- [ ] Have you checked if it works normally in all models? *Ignore this
if it doesn't use models.*
- [x] Have you checked if it works normally in all web, local, and node
hosted versions? If it doesn't, have you blocked it in those versions?
- [ ] Have you added type definitions?

# Description
Have to revise, if possible. But really didn't changed that much logic
and since it is only a typescript file change, it will work on most
cases.

Worked on node hosted chrome environment with 2.25GB of binary backup
file.
This commit is contained in:
kwaroran
2025-01-03 18:58:26 +09:00
committed by GitHub
parent 821ba1812f 48b377b1ad
commit bf8bf02e2f
1 changed files with 88 additions and 64 deletions
Download Patch File Download Diff File Expand all files Collapse all files

150
src/ts/drive/backuplocal.ts
View File

@@ -14,7 +14,6 @@ function getBasename(data:string){
return lasts
}
export async function SaveLocalBackup(){
alertWait("Saving local backup...")
const writer = new LocalWriter()
@@ -37,7 +36,6 @@ export async function SaveLocalBackup(){
return
}
if(isTauri){
const assets = await readDir('assets', {baseDir: BaseDirectory.AppData})
let i = 0;
@@ -80,74 +78,100 @@ export async function SaveLocalBackup(){
}
export async function LoadLocalBackup(){
//select file
try {
const input = document.createElement('input')
input.type = 'file'
input.accept = '.bin'
const input = document.createElement('input');
input.type = 'file';
input.accept = '.bin';
input.onchange = async () => {
if(!input.files || input.files.length === 0){
input.remove()
return
if (!input.files || input.files.length === 0) {
input.remove();
return;
}
const file = input.files[0]
const reader = new FileReader()
input.remove()
reader.onload = async () => {
const buffer = reader.result as ArrayBuffer
const bufferLength = buffer.byteLength
for(let i=0;i<bufferLength;){
const progress = (i / bufferLength * 100).toFixed(2)
alertWait(`Loading local Backup... (${progress}%)`)
const file = input.files[0];
input.remove();
const nameLength = new Uint32Array(buffer.slice(i, i+4))[0]
i += 4
const name = new TextDecoder().decode(new Uint8Array(buffer.slice(i, i+nameLength)))
i += nameLength
const dataLength = new Uint32Array(buffer.slice(i, i+4))[0]
i += 4
const data = new Uint8Array(buffer.slice(i, i+dataLength))
i += dataLength
if(name === 'database.risudat'){
const db = new Uint8Array(data)
const dbData = await decodeRisuSave(db)
setDatabaseLite(dbData)
if(isTauri){
await writeFile('database/database.bin', db, {baseDir: BaseDirectory.AppData})
relaunch()
alertStore.set({
type: "wait",
msg: "Success, Refreshing your app."
})
}
else{
await forageStorage.setItem('database/database.bin', db)
location.search = ''
alertStore.set({
type: "wait",
msg: "Success, Refreshing your app."
})
}
continue
}
if(isTauri){
await writeFile(`assets/` + name, data ,{baseDir: BaseDirectory.AppData})
}
else{
await forageStorage.setItem('assets/' + name, data)
}
await sleep(10)
if(forageStorage.isAccount){
await sleep(1000)
}
const reader = file.stream().getReader();
const CHUNK_SIZE = 1024 * 1024; // 1MB chunk size
let bytesRead = 0;
let remainingBuffer = new Uint8Array();
while (true) {
const { done, value } = await reader.read();
if (done) {
break;
}
}
reader.readAsArrayBuffer(file)
}
input.click()
bytesRead += value.length;
const progress = ((bytesRead / file.size) * 100).toFixed(2);
alertWait(`Loading local Backup... (${progress}%)`);
const newBuffer = new Uint8Array(remainingBuffer.length + value.length);
newBuffer.set(remainingBuffer);
newBuffer.set(value, remainingBuffer.length);
remainingBuffer = newBuffer;
let offset = 0;
while (offset + 4 <= remainingBuffer.length) {
const nameLength = new Uint32Array(remainingBuffer.slice(offset, offset + 4).buffer)[0];
if (offset + 4 + nameLength > remainingBuffer.length) {
break;
}
const nameBuffer = remainingBuffer.slice(offset + 4, offset + 4 + nameLength);
const name = new TextDecoder().decode(nameBuffer);
if (offset + 4 + nameLength + 4 > remainingBuffer.length) {
break;
}
const dataLength = new Uint32Array(remainingBuffer.slice(offset + 4 + nameLength, offset + 4 + nameLength + 4).buffer)[0];
if (offset + 4 + nameLength + 4 + dataLength > remainingBuffer.length) {
break;
}
const data = remainingBuffer.slice(offset + 4 + nameLength + 4, offset + 4 + nameLength + 4 + dataLength);
if (name === 'database.risudat') {
const db = new Uint8Array(data);
const dbData = await decodeRisuSave(db);
setDatabaseLite(dbData);
if (isTauri) {
await writeFile('database/database.bin', db, { baseDir: BaseDirectory.AppData });
await relaunch();
alertStore.set({
type: "wait",
msg: "Success, Refreshing your app."
});
} else {
await forageStorage.setItem('database/database.bin', db);
location.search = '';
alertStore.set({
type: "wait",
msg: "Success, Refreshing your app."
});
}
} else {
if (isTauri) {
await writeFile(`assets/` + name, data, { baseDir: BaseDirectory.AppData });
} else {
await forageStorage.setItem('assets/' + name, data);
}
}
await sleep(10);
if (forageStorage.isAccount) {
await sleep(1000);
}
offset += 4 + nameLength + 4 + dataLength;
}
remainingBuffer = remainingBuffer.slice(offset);
}
alertNormal('Success');
};
input.click();
} catch (error) {
console.error(error)
console.error(error);
alertError('Failed, Is file corrupted?')
}
}