+
+ {/if}
+
{#if activeView === 'clients' && data.currentUser?.es_admin}
@@ -2403,9 +2326,7 @@
{/if}
-
-
-
+
{#if showDbCrudModal}
diff --git a/src/routes/backup/+server.ts b/src/routes/backup/+server.ts
index bcba839..c4ba12e 100644
--- a/src/routes/backup/+server.ts
+++ b/src/routes/backup/+server.ts
@@ -3,18 +3,63 @@ import { createReadStream } from 'node:fs';
import fs from 'node:fs/promises';
import path from 'node:path';
import { Readable } from 'node:stream';
+import { logger } from '$lib/server/logger';
+import { openBackupDownload, BackupDownloadError, type BackupKind } from '$lib/server/restore-fetch';
import type { RequestHandler } from './$types';
-// GET /backup?file=nombre.bak -> descarga el archivo físico desde BACKUP_PATH (streaming; soporta archivos muy grandes)
+// GET /backup?target=&kind=&file=
+// Descarga por restaurador y RELATIVA (sin rutas fijas): la base la resuelve el servidor
+// desde lo que reporta ese restaurador; el archivo se transmite por fs local o SFTP.
+// GET /backup?file= (legacy): descarga desde BACKUP_PATH local.
export const GET: RequestHandler = async ({ url, request }) => {
const fileName = url.searchParams.get('file');
if (!fileName) {
return new Response('Missing file parameter', { status: 400 });
}
+ const targetRaw = url.searchParams.get('target');
+ if (targetRaw) {
+ return handleByTarget(targetRaw, url.searchParams.get('kind'), fileName, request);
+ }
+ return handleLegacyBackupPath(fileName, request);
+};
+
+/** Descarga por restaurador (procesados/fallados) resolviendo la base al vuelo. */
+async function handleByTarget(
+ targetRaw: string,
+ kindRaw: string | null,
+ fileName: string,
+ request: Request
+): Promise {
+ const targetId = Number(targetRaw);
+ if (!Number.isInteger(targetId) || targetId <= 0) {
+ return new Response('Invalid target parameter', { status: 400 });
+ }
+ const kind: BackupKind = kindRaw === 'fallados' ? 'fallados' : 'procesados';
+
+ try {
+ const dl = await openBackupDownload(targetId, kind, fileName);
+ request.signal.addEventListener('abort', () => dl.cleanup());
+ const headers = new Headers();
+ headers.set('Content-Type', 'application/octet-stream');
+ headers.set('Content-Disposition', `attachment; filename="${dl.filename}"`);
+ if (dl.size != null) headers.set('Content-Length', String(dl.size));
+ return new Response(dl.body, { status: 200, headers });
+ } catch (e) {
+ if (e instanceof BackupDownloadError) {
+ return new Response(e.message, { status: e.status });
+ }
+ const msg = e instanceof Error ? e.message : String(e);
+ logger.error({ message: 'Error en descarga por restaurador', context: { error: msg, targetId } });
+ return new Response('Backup file not found or inaccessible', { status: 404 });
+ }
+}
+
+/** Modo legacy: sirve el archivo desde BACKUP_PATH local (carpeta única configurada). */
+async function handleLegacyBackupPath(fileName: string, request: Request): Promise {
const basePath = env.BACKUP_PATH;
if (!basePath) {
- console.error('BACKUP_PATH is not defined in environment');
+ logger.error({ message: 'BACKUP_PATH no está definido en el entorno' });
return new Response('Backup path is not configured', { status: 500 });
}
@@ -28,10 +73,9 @@ export const GET: RequestHandler = async ({ url, request }) => {
try {
const st = await fs.stat(filePath);
if (!st.isFile()) {
- console.error('Backup path is not a regular file:', filePath);
return new Response('Backup file not found or inaccessible', { status: 404 });
}
- console.log('Serving backup file from', filePath, 'size', st.size);
+ const downloadName = path.basename(filePath);
const nodeStream = createReadStream(filePath, { highWaterMark: 1024 * 1024 });
request.signal.addEventListener('abort', () => {
nodeStream.destroy();
@@ -39,12 +83,12 @@ export const GET: RequestHandler = async ({ url, request }) => {
const body = Readable.toWeb(nodeStream) as unknown as ReadableStream;
const headers = new Headers();
headers.set('Content-Type', 'application/octet-stream');
- headers.set('Content-Disposition', `attachment; filename="${fileName}"`);
+ headers.set('Content-Disposition', `attachment; filename="${downloadName}"`);
headers.set('Content-Length', String(st.size));
return new Response(body, { status: 200, headers });
} catch (e: unknown) {
const msg = e instanceof Error ? e.message : String(e);
- console.error('Error serving backup file:', msg);
+ logger.error({ message: 'Error al servir archivo de respaldo', context: { error: msg } });
return new Response('Backup file not found or inaccessible', { status: 404 });
}
-};
+}
diff --git a/src/routes/reportes/+page.svelte b/src/routes/reportes/+page.svelte
index 315ed77..045a2a5 100644
--- a/src/routes/reportes/+page.svelte
+++ b/src/routes/reportes/+page.svelte
@@ -1,5 +1,6 @@
-
+
+
+
+
Servidores de Restauración
- Configura IP, credenciales y rutas de cada servidor. La asignación de cada base a
- un servidor se hace en Gestión de Bases de Datos (un radio por base).
+ Configura IP, credenciales, rutas y capacidad de cada servidor, y asigna qué bases
+ restaura cada uno (checklist o distribución automática por capacidad).
@@ -118,79 +707,355 @@
{/if}
{#if form?.success}
-
+
Operación realizada correctamente.
{/if}
+ {#if successMsg}
+
+ check_circle
+ {successMsg}
+
+ {/if}
{#if data.dbWarning}
{data.dbWarning}
{/if}
+
-
CloudRestoreAS por servidor
-
- Cada servidor de restauración puede tener su propia instalación de CloudRestoreAS.
- La carpeta de entrada se configura en cada equipo; el panel solo la muestra.
-
+
Servidores
{#if targets.length === 0}
Crea un servidor con + Nuevo servidor.
{:else}
-
- {#each targets as t (t.id)}
- {@const cra = statusForTarget(t.name)}
-
+