geneafinder_v7_maintenance

https://www.npmjs.com/package/memjs memcached pour stocker temporairement la progression

const express = require('express');
const memjs = require('memjs');

const app = express();
const mc = memjs.Client.create(process.env.MEMCACHIER_SERVERS || 'localhost:11211');

// Fonction pour mettre à jour la progression
async function updateProgress(fileId, progress) {
try {
await mc.set(`file_progress_${fileId}`, JSON.stringify(progress), {expires: 600}); // expire après 10 minutes
} catch (error) {
console.error('Erreur lors de la mise à jour de la progression:', error);
}
}

// Fonction pour récupérer la progression
async function getProgress(fileId) {
try {
const { value } = await mc.get(`file_progress_${fileId}`);
return value ? JSON.parse(value.toString()) : null;
} catch (error) {
console.error('Erreur lors de la récupération de la progression:', error);
return null;
}
}

// Simuler l'analyse d'un fichier
async function analyzeFile(fileId) {
for (let i = 0; i <= 100; i += 10) {
await updateProgress(fileId, { progress: i });
await new Promise(resolve => setTimeout(resolve, 1000)); // Attendre 1 seconde
}
}

// Route pour démarrer l'analyse
app.get('/start-analysis/:fileId', (req, res) => {
const fileId = req.params.fileId;
analyzeFile(fileId);
res.json({ message: 'Analyse démarrée' });
});

// Route pour obtenir la progression
app.get('/progress/:fileId', async (req, res) => {
const fileId = req.params.fileId;
const progress = await getProgress(fileId);
res.json(progress || { progress: 0 });
});

const PORT = process.env.PORT || 3000;
app.listen(PORT, () => {
console.log(`Serveur en écoute sur le port ${PORT}`);
});

L'ia conseille aussi socket io