Update index.js

index.js

@@ -2,15 +2,15 @@ import 'dotenv/config';
 import express from 'express';
 import path from 'path';
 import fs from 'fs';
-import { fileURLToPath } from 'url';
 import { execSync } from 'child_process';
+import { fileURLToPath } from 'url';
 import RemoteFetcher from './lib/remote.js';
 
 const __filename = fileURLToPath(import.meta.url);
 const __dirname = path.dirname(__filename);
 
 const app = express();
-const PORT = process.env.PORT || 7861; // Puerto diferente para no chocar
+const PORT = process.env.PORT || 7860;
 
 const STORAGE_DIR = path.join(__dirname, 'storage');
 const TEMP_DIR = path.join(__dirname, 'temp');
@@ -19,16 +19,38 @@ if (!fs.existsSync(STORAGE_DIR)) fs.mkdirSync(STORAGE_DIR, { recursive: true });
 if (!fs.existsSync(TEMP_DIR)) fs.mkdirSync(TEMP_DIR, { recursive: true });
 
 app.use(express.static('public'));
-app.use('/view', express.static(STORAGE_DIR));
 
-// Endpoint ultra simple: Listar archivos en disco
+let currentZipPath = null;
+let currentFileList = [];
+
+// Endpoint para listar archivos dentro del ZIP actual
 app.get('/api/files', (req, res) => {
-    const files = fs.readdirSync(STORAGE_DIR).filter(f => !f.startsWith('.'));
-    res.json(files);
+    res.json(currentFileList);
+});
+
+// Ver acta: Extraer solo el archivo solicitado del ZIP
+app.get('/view/:filename', (req, res) => {
+    if (!currentZipPath || !fs.existsSync(currentZipPath)) {
+        return res.status(404).send('No hay paquete cargado o el archivo se borró.');
+    }
+    
+    const fileName = req.params.filename;
+    const outputPath = path.join(TEMP_DIR, fileName);
+
+    try {
+        // Extraemos SOLO este archivo del ZIP
+        execSync(`unzip -p "${currentZipPath}" "${fileName}" > "${outputPath}"`);
+        res.sendFile(outputPath, () => {
+            // Borramos el temporal después de enviar
+            try { fs.unlinkSync(outputPath); } catch(e) {}
+        });
+    } catch (e) {
+        res.status(500).send('Error al extraer el acta.');
+    }
 });
 
 app.listen(PORT, () => {
-    console.log(`🚀 Servidor SIMPLE corriendo en puerto ${PORT}`);
+    console.log(`🚀 Servidor SIMPLE (Bajo Demanda) en puerto ${PORT}`);
     startSimpleWorker();
 });
 
@@ -45,41 +67,40 @@ async function startSimpleWorker() {
         await fetcher.connect();
         console.log('✅ Conexión SSH lista.');
 
-        const remoteRoot = '/home/user110426@vi/ACTAS'; 
-        const regions = await fetcher.listDirectories(remoteRoot);
+        const regions = ['AFRICA', 'OCEANIA', 'ASIA', 'CALLAO', 'PIURA', 'LIMA', 'LA_LIBERTAD', 'AREQUIPA', 'CUSCO', 'CAJAMARCA'];
 
-        for (const region of regions) {
-            console.log(`🌍 Entrando a: ${region}`);
-            const regionPath = path.posix.join(remoteRoot, region);
+        for (const regionName of regions) {
+            const regionPath = `/home/user110426@vi/ACTAS/${regionName}`;
             const zips = await fetcher.listFiles(regionPath, '.zip');
 
             for (const zipName of zips) {
-                const localZipPath = path.join(TEMP_DIR, zipName);
+                const localZipPath = path.join(STORAGE_DIR, zipName);
                 const remoteZipPath = path.posix.join(regionPath, zipName);
 
-                // LIMPIEZA: Para no llenar el disco de 50GB, borramos lo anterior antes de cada ZIP nuevo
-                console.log(`🧹 Limpiando espacio para ${zipName}...`);
-                const oldFiles = fs.readdirSync(STORAGE_DIR);
-                for (const f of oldFiles) {
-                    try { fs.unlinkSync(path.join(STORAGE_DIR, f)); } catch(e) {}
+                // LIMPIEZA: Borramos el ZIP anterior para dejar espacio al nuevo
+                if (currentZipPath && fs.existsSync(currentZipPath)) {
+                    console.log(`🧹 Borrando paquete anterior para liberar espacio...`);
+                    fs.unlinkSync(currentZipPath);
                 }
 
                 console.log(`📦 Descargando ${zipName}...`);
                 await fetcher.fetchFile(remoteZipPath, localZipPath);
-
-                console.log(`📂 Descomprimiendo ${zipName}...`);
-                try {
-                    execSync(`unzip -o "${localZipPath}" -d "${STORAGE_DIR}"`);
-                } catch (e) {
-                    console.log(`❌ Error unzip: ${e.message}`);
-                }
                 
-                // Borramos el zip inmediatamente
-                if (fs.existsSync(localZipPath)) fs.unlinkSync(localZipPath);
-                console.log(`✨ ${zipName} listo para auditar.`);
+                currentZipPath = localZipPath;
+
+                // Listamos los archivos del ZIP sin extraerlos
+                console.log(`📜 Listando actas de ${zipName}...`);
+                const listOutput = execSync(`unzip -l "${localZipPath}"`).toString();
+                currentFileList = listOutput.split('\n')
+                    .filter(line => line.includes('.jpg') || line.includes('.pdf') || line.includes('.png'))
+                    .map(line => line.trim().split(/\s+/).pop());
+
+                console.log(`✨ ${zipName} listo. ${currentFileList.length} actas detectadas.`);
             }
         }
     } catch (err) {
-        console.error(`❌ Error SimpleWorker: ${err.message}`);
+        console.log(`❌ Error: ${err.message}`);
+    } finally {
+        fetcher.disconnect();
     }
 }