server.js

const http = require('http');
const { spawn } = require('child_process');
const fs = require('fs');
const url = require('url');

const PORT = 8000;

const html = fs.readFileSync('./index.html');

let ffmpegProcess = null;
let camActive = false;
let streamClients = [];

function startFFmpeg() {
    if (ffmpegProcess) return;

    ffmpegProcess = spawn('ffmpeg', [
        '-f', 'video4linux2',
        '-input_format', 'mjpeg',
        '-fflags', 'nobuffer',
        '-flags', 'low_delay',
        '-i', '/dev/video0',
        '-vf', 'scale=640:480',
        '-r', '15',
        '-f', 'mjpeg',
        '-q:v', '7',
        '-an',
        '-'
    ]);

    ffmpegProcess.stdout.on('data', (chunk) => {
        streamClients.forEach((res) => {
            try {
                res.write(`--frame\r\n`);
                res.write(`Content-Type: image/jpeg\r\n`);
                res.write(`Content-Length: ${chunk.length}\r\n\r\n`);
                res.write(chunk);
                res.write('\r\n');
            } catch (err) {
                console.log('Erreur écriture stream:', err.message);
            }
        });
    });

    ffmpegProcess.stderr.on('data', (data) => {
        // console.error('ffmpeg stderr:', data.toString()); // décommenter pour debug
    });

    ffmpegProcess.on('close', (code) => {
        console.log('ffmpeg stoppé avec code', code);
        ffmpegProcess = null;
        camActive = false;
        // Fermer tous les clients stream
        streamClients.forEach((res) => { try { res.end(); } catch {} });
        streamClients = [];
    });

    camActive = true;
    console.log('✅ Caméra démarrée');
}

function stopFFmpeg() {
    if (ffmpegProcess) {
        ffmpegProcess.kill('SIGINT');
        ffmpegProcess = null;
    }
    camActive = false;
    streamClients.forEach((res) => { try { res.end(); } catch {} });
    streamClients = [];
    console.log('🛑 Caméra arrêtée');
}

http.createServer((req, res) => {
    const parsedUrl = url.parse(req.url, true);
    const pathname = parsedUrl.pathname;

    // CORS basique pour les requêtes fetch
    res.setHeader('Access-Control-Allow-Origin', '*');

    if (pathname === '/') {
        res.writeHead(200, { 'Content-Type': 'text/html' });
        res.end(html);
        return;
    }

    // Statut de la cam
    if (pathname === '/status') {
        res.writeHead(200, { 'Content-Type': 'application/json' });
        res.end(JSON.stringify({ active: camActive }));
        return;
    }

    // Activer la cam
    if (pathname === '/cam/on') {
        startFFmpeg();
        res.writeHead(200, { 'Content-Type': 'application/json' });
        res.end(JSON.stringify({ active: true }));
        return;
    }

    // Désactiver la cam
    if (pathname === '/cam/off') {
        stopFFmpeg();
        res.writeHead(200, { 'Content-Type': 'application/json' });
        res.end(JSON.stringify({ active: false }));
        return;
    }

    // Stream MJPEG
    if (pathname === '/stream') {
        if (!camActive) {
            res.writeHead(503, { 'Content-Type': 'text/plain' });
            res.end('Caméra inactive');
            return;
        }

        res.writeHead(200, {
            'Content-Type': 'multipart/x-mixed-replace; boundary=frame',
            'Cache-Control': 'no-cache',
            'Connection': 'keep-alive',
            'Pragma': 'no-cache'
        });

        console.log('Client connecté au stream');
        streamClients.push(res);

        req.on('close', () => {
            console.log('Client déconnecté');
            streamClients = streamClients.filter(c => c !== res);
        });

        return;
    }

    res.writeHead(404);
    res.end();

}).listen(PORT, '0.0.0.0', () => {
    console.log(`✅ Stream dispo sur http://100.127.151.6:${PORT}`);
});