prehistoric-systems/bewcloud
1
0
Fork 0
mirror of https://github.com/bewcloud/bewcloud.git synced 2026-03-11 08:54:49 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Fix linting, formatting

Browse source
This commit is contained in:
Tilman 2025-12-03 00:17:32 +01:00
parent 990ce73ecf
commit 64b5567cf2
1 changed files with 39 additions and 38 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

77
routes/api/files/download-directory.tsx
View file

@ -1,5 +1,6 @@
import { Handlers } from 'fresh/server.ts';
import { join } from '@std/path';
import { Buffer } from 'node:buffer';
import JSZip from 'jszip';
import { FreshContextState } from '/lib/types.ts';
@ -8,6 +9,42 @@ import { ensureUserPathIsValidAndSecurelyAccessible } from '/lib/models/files.ts
interface Data {}
// Recursively add files to the zip with optimizations
async function addFilesToZip(currentPath: string, zipFolder: JSZip, basePath = '') {
const entries = [];
for await (const entry of Deno.readDir(currentPath)) {
entries.push(entry);
}
// Process files in parallel batches
const batchSize = 10;
for (let i = 0; i < entries.length; i += batchSize) {
const batch = entries.slice(i, i + batchSize);
await Promise.all(
batch.map(async (entry) => {
const entryPath = join(currentPath, entry.name);
const relativePath = basePath ? `${basePath}/${entry.name}` : entry.name;
if (entry.isFile) {
// Use async file reading with streaming hint
const fileContent = await Deno.readFile(entryPath);
zipFolder.file(entry.name, fileContent, {
binary: true,
createFolders: false,
});
} else if (entry.isDirectory) {
// Create a folder in the zip and recursively add its contents
const subFolder = zipFolder.folder(entry.name);
if (subFolder) {
await addFilesToZip(entryPath, subFolder, relativePath);
}
}
}),
);
}
}
export const handler: Handlers<Data, FreshContextState> = {
async GET(request, context) {
if (!context.state.user) {
@ -43,42 +80,6 @@ export const handler: Handlers<Data, FreshContextState> = {
// Create a JSZip instance
const zip = new JSZip();
// Recursively add files to the zip with optimizations
async function addFilesToZip(currentPath: string, zipFolder: JSZip, basePath = '') {
const entries = [];
for await (const entry of Deno.readDir(currentPath)) {
entries.push(entry);
}
// Process files in parallel batches
const batchSize = 10;
for (let i = 0; i < entries.length; i += batchSize) {
const batch = entries.slice(i, i + batchSize);
await Promise.all(
batch.map(async (entry) => {
const entryPath = join(currentPath, entry.name);
const relativePath = basePath ? `${basePath}/${entry.name}` : entry.name;
if (entry.isFile) {
// Use async file reading with streaming hint
const fileContent = await Deno.readFile(entryPath);
zipFolder.file(entry.name, fileContent, {
binary: true,
createFolders: false,
});
} else if (entry.isDirectory) {
// Create a folder in the zip and recursively add its contents
const subFolder = zipFolder.folder(entry.name);
if (subFolder) {
await addFilesToZip(entryPath, subFolder, relativePath);
}
}
})
);
}
}
// Add all files from the directory
await addFilesToZip(fullDirectoryPath, zip);
@ -87,14 +88,14 @@ export const handler: Handlers<Data, FreshContextState> = {
type: 'nodebuffer',
streamFiles: true,
compression: 'DEFLATE',
compressionOptions: {
compressionOptions: {
level: 1,
},
});
// Convert Node.js stream to Web ReadableStream
const readableStream = new ReadableStream({
async start(controller) {
start(controller) {
let isCancelled = false;
zipStream.on('data', (chunk: Buffer) => {