fast server for auditory of acts

Dockerfile

@@ -0,0 +1,19 @@
+FROM node:20
+
+# Instalamos unzip para los paquetes
+RUN apt-get update && apt-get install -y unzip && rm -rf /var/lib/apt/lists/*
+
+WORKDIR /app
+
+COPY package*.json ./
+RUN npm install
+
+COPY . .
+
+# Creamos las carpetas necesarias con permisos
+RUN mkdir -p storage temp && chmod 777 storage temp
+
+EXPOSE 7860
+ENV PORT=7860
+
+CMD ["node", "index.js"]

index.js

@@ -0,0 +1,78 @@
+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 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 STORAGE_DIR = path.join(__dirname, 'storage');
+const TEMP_DIR = path.join(__dirname, 'temp');
+
+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
+app.get('/api/files', (req, res) => {
+    const files = fs.readdirSync(STORAGE_DIR).filter(f => !f.startsWith('.'));
+    res.json(files);
+});
+
+app.listen(PORT, () => {
+    console.log(`🚀 Servidor SIMPLE corriendo en puerto ${PORT}`);
+    startSimpleWorker();
+});
+
+async function startSimpleWorker() {
+    const config = {
+        host: process.env.REMOTE_HOST,
+        username: process.env.REMOTE_USER,
+        password: process.env.REMOTE_PASS,
+        port: parseInt(process.env.REMOTE_PORT || 22)
+    };
+
+    const fetcher = new RemoteFetcher(config);
+    try {
+        await fetcher.connect();
+        console.log('✅ Conexión SSH lista.');
+
+        const remoteRoot = '/home/user110426@vi/ACTAS'; 
+        const regions = await fetcher.listDirectories(remoteRoot);
+
+        for (const region of regions) {
+            console.log(`🌍 Entrando a: ${region}`);
+            const regionPath = path.posix.join(remoteRoot, region);
+            const zips = await fetcher.listFiles(regionPath, '.zip');
+
+            for (const zipName of zips) {
+                const localZipPath = path.join(TEMP_DIR, zipName);
+                const remoteZipPath = path.posix.join(regionPath, zipName);
+
+                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 para no llenar el disco
+                fs.unlinkSync(localZipPath);
+                console.log(`✨ ${zipName} listo.`);
+            }
+        }
+    } catch (err) {
+        console.error(`❌ Error SimpleWorker: ${err.message}`);
+    }
+}

lib/remote.js

@@ -0,0 +1,86 @@
+import { Client } from 'ssh2';
+import fs from 'fs';
+import path from 'path';
+
+export default class RemoteFetcher {
+    constructor(config) {
+        this.config = {
+            host: config.host,
+            port: config.port || 22,
+            username: config.username,
+            password: config.password,
+            readyTimeout: 40000,
+            keepaliveInterval: 10000
+        };
+        this.conn = new Client();
+    }
+
+    connect() {
+        return new Promise((resolve, reject) => {
+            this.conn.on('ready', () => {
+                this.conn.sftp((err, sftp) => {
+                    if (err) return reject(err);
+                    this.sftp = sftp;
+                    resolve();
+                });
+            })
+            .on('error', (err) => reject(err))
+            .connect(this.config);
+        });
+    }
+
+    // Volvemos a fastGet pero con configuración optimizada para velocidad/estabilidad
+    async fetchFile(remotePath, localPath, onProgress) {
+        return new Promise((resolve, reject) => {
+            this.sftp.fastGet(remotePath, localPath, {
+                concurrency: 6, // 6 descargas en paralelo para mayor velocidad
+                chunkSize: 32768, // Bloques de 32KB
+                step: (transferred, chunk, total) => {
+                    if (onProgress) onProgress(transferred, total);
+                }
+            }, (err) => {
+                if (err) return reject(err);
+                resolve();
+            });
+        });
+    }
+
+    async listFiles(remoteDir, extension = '') {
+        return new Promise((resolve, reject) => {
+            this.sftp.readdir(remoteDir, (err, list) => {
+                if (err) return reject(err);
+                const files = list
+                    .filter(f => f.attrs.isFile())
+                    .map(f => f.filename);
+                
+                if (extension) {
+                    resolve(files.filter(f => f.toLowerCase().endsWith(extension.toLowerCase())));
+                } else {
+                    resolve(files);
+                }
+            });
+        });
+    }
+
+    async listDirectories(remoteDir) {
+        return new Promise((resolve, reject) => {
+            this.sftp.readdir(remoteDir, (err, list) => {
+                if (err) return reject(err);
+                resolve(list.filter(f => f.attrs.isDirectory() && f.filename !== '.' && f.filename !== '..').map(f => f.filename));
+            });
+        });
+    }
+
+    async getFileStats(remotePath) {
+        return new Promise((resolve, reject) => {
+            this.sftp.stat(remotePath, (err, stats) => {
+                if (err) return reject(err);
+                resolve(stats);
+            });
+        });
+    }
+
+    disconnect() {
+        this.conn.end();
+    }
+}

package.json

@@ -0,0 +1,11 @@
+{
+  "name": "votolibre-simpleserver",
+  "version": "1.0.0",
+  "type": "module",
+  "main": "index.js",
+  "dependencies": {
+    "dotenv": "^16.4.5",
+    "express": "^4.19.2",
+    "ssh2": "^1.15.0"
+  }
+}

public/index.html

@@ -0,0 +1,61 @@
+<!DOCTYPE html>
+<html lang="es">
+<head>
+    <meta charset="UTF-8">
+    <title>VotoLibre | Fast Audit</title>
+    <style>
+        body { font-family: sans-serif; padding: 20px; background: #f4f4f9; color: #333; }
+        .container { max-width: 800px; margin: 0 auto; background: white; padding: 30px; border-radius: 10px; box-shadow: 0 2px 10px rgba(0,0,0,0.1); }
+        h1 { color: #2c3e50; border-bottom: 2px solid #3498db; padding-bottom: 10px; }
+        input { width: 100%; padding: 10px; margin: 20px 0; border: 1px solid #ddd; border-radius: 5px; }
+        ul { list-style: none; padding: 0; }
+        li { padding: 10px; border-bottom: 1px solid #eee; display: flex; justify-content: space-between; }
+        li:hover { background: #f9f9f9; }
+        a { color: #3498db; text-decoration: none; font-weight: bold; }
+        a:hover { text-decoration: underline; }
+        .count { font-size: 0.9em; color: #666; }
+    </style>
+</head>
+<body>
+    <div class="container">
+        <h1>VotoLibre FastTrack Audit</h1>
+        <p>Lista simple de actas descargadas en tiempo real.</p>
+        <div class="count">Actas disponibles: <span id="count">0</span></div>
+        <input type="text" id="search" placeholder="Buscar acta por número..." onkeyup="filter()">
+        <ul id="list">
+            <li>Cargando archivos...</li>
+        </ul>
+    </div>
+
+    <script>
+        let allFiles = [];
+        async function load() {
+            try {
+                const res = await fetch('/api/files');
+                allFiles = await res.json();
+                document.getElementById('count').innerText = allFiles.length;
+                render(allFiles);
+            } catch (e) {}
+        }
+
+        function render(list) {
+            const ul = document.getElementById('list');
+            ul.innerHTML = list.map(f => `
+                <li>
+                    <span>${f}</span>
+                    <a href="/view/${f}" target="_blank">Abrir Imagen</a>
+                </li>
+            `).join('');
+        }
+
+        function filter() {
+            const q = document.getElementById('search').value.toLowerCase();
+            const filtered = allFiles.filter(f => f.toLowerCase().includes(q));
+            render(filtered);
+        }
+
+        setInterval(load, 5000);
+        load();
+    </script>
+</body>
+</html>