const { execFile } = require("child_process");
const { userYtDlp } = require("../helpers/path");
const path = require("path");
const fs = require("fs");
const { logger } = require("../logger");
const { buildYtDlpArgs } = require("../helpers/buildArgs");

function fetchDownload(options, listeners, speedListeners) {

  return new Promise((resolve, reject) => {
    const outputFolder = options.outputFolder || path.join(process.env.USERPROFILE, "Downloads", "Freedom Loader");
    fs.mkdirSync(outputFolder, { recursive: true });

    const args = buildYtDlpArgs({ ...options, outputFolder });
    logger.info(`[yt-dlp args] ${args.join(" ")}`);

    const child = execFile(userYtDlp, args);

    child.on("error", err => reject(new Error(`Erreur yt-dlp : ${err.message}`)));

    child.on("close", code => {
      listeners.forEach(fn => fn("done"));
      if (code === 0) resolve(outputFolder);
      else reject(new Error(`yt-dlp a échoué avec le code : ${code}`));
    });

    
    child.stdout.on("data", data => {
      data.toString().split("\n").forEach(line => {
        if (!line.trim()) return;
        logger.info(`[yt-dlp stdout] ${line}`);

        /* Barre de Chargement*/
        if (line.startsWith("[download] Destination:")) listeners.forEach(fn => fn("reset"));
        const match = line.match(/\[download\]\s+(\d+\.\d+)%/);
        if (match) listeners.forEach(fn => fn(parseFloat(match[1])));

        if (line.includes("MiB/s") || line.includes("KiB/s")) {
            const match = line.match(/\d+(\.\d+)?[KM]?iB\/s/);
            if (match) {
                const speed = match[0];
                speedListeners.forEach(fn => fn(speed));
            }
        }


      });
    });

    child.stderr.on("data", data => {
      data.toString().split("\n").forEach(line => line.trim() && logger.error(`[yt-dlp stderr] ${line}`));
    });

    
  });
}

module.exports = { fetchDownload };