/**
 * Service de récupération automatique des factures FreePro
 *
 * Le portail FreePro (https://pro.free.fr) est une SPA Angular.
 * La connexion se fait via un formulaire HTML : il n'existe pas d'endpoint
 * REST public accessible en fetch simple.
 *
 * Stratégie adoptée :
 * 1. Tenter de télécharger directement le CSV de la facture du mois courant
 *    via l'URL https://pro.free.fr/account/invoice/{REF}/primary_csv après
 *    avoir obtenu un cookie de session via le formulaire de login.
 * 2. Si l'accès direct échoue, retourner un message d'erreur explicite.
 *
 * Pour le test de connexion, on vérifie que la page /account/ est accessible
 * avec les cookies obtenus — ce qui confirme que les credentials sont valides.
 */

import { getFreeproSettings, updateFreeproLastRun, createFreeproImport, getFreeproImportsByUser } from "./db";
import { processFreeproExcel } from "./freeproService";

// ── Types ──────────────────────────────────────────────────────────────────

interface FreeproInvoice {
  invoiceNumber: string;
  date: string;
  amount: number;
  month: string;
}

interface AutoImportResult {
  success: boolean;
  imported: number;
  skipped: number;
  errors: string[];
  message: string;
}

// ── Constantes ─────────────────────────────────────────────────────────────

const FREEPRO_BASE_URL = "https://pro.free.fr";
const LOGIN_URL = `${FREEPRO_BASE_URL}/espace-client/connexion/#/`;
const LOGIN_FORM_URL = `${FREEPRO_BASE_URL}/espace-client/connexion/`;
const ACCOUNT_URL = `${FREEPRO_BASE_URL}/account/`;
const BILLING_URL = `${FREEPRO_BASE_URL}/account/billing`;

/** Timeout en ms pour les requêtes HTTP vers FreePro */
const HTTP_TIMEOUT_MS = 15_000;

// ── Helpers ────────────────────────────────────────────────────────────────

/**
 * fetch avec timeout intégré
 */
async function fetchWithTimeout(url: string, options: RequestInit = {}, timeoutMs = HTTP_TIMEOUT_MS): Promise<Response> {
  const controller = new AbortController();
  const timer = setTimeout(() => controller.abort(), timeoutMs);
  try {
    return await fetch(url, { ...options, signal: controller.signal });
  } finally {
    clearTimeout(timer);
  }
}

/**
 * Extrait les cookies d'un header set-cookie
 */
function extractCookies(setCookieHeader: string | null): string {
  if (!setCookieHeader) return "";
  return setCookieHeader
    .split(",")
    .map((c) => c.split(";")[0].trim())
    .filter(Boolean)
    .join("; ");
}

/**
 * Calcule le label du mois précédent (les factures FreePro arrivent en début de mois suivant)
 */
function previousMoisLabel(): string {
  const now = new Date();
  now.setMonth(now.getMonth() - 1);
  const m = String(now.getMonth() + 1).padStart(2, "0");
  const y = String(now.getFullYear());
  return `${m}/${y}`;
}

// ── Connexion au portail FreePro ───────────────────────────────────────────

/**
 * Tente de se connecter au portail FreePro via le formulaire HTML.
 *
 * Le portail est une SPA Angular. La connexion passe par :
 * 1. GET /espace-client/connexion/ → récupérer les cookies initiaux
 * 2. POST sur l'endpoint de soumission du formulaire avec les credentials
 * 3. Vérification que la page /account/ est accessible (HTTP 200 non-redirigé)
 *
 * Retourne les cookies de session si la connexion réussit.
 */
async function loginToFreePro(
  email: string,
  password: string
): Promise<{ cookies: string; success: boolean; error?: string }> {
  try {
    // ── Étape 1 : récupérer la page de login pour les cookies initiaux ──
    let initialCookies = "";
    try {
      const loginPageResp = await fetchWithTimeout(LOGIN_FORM_URL, {
        method: "GET",
        headers: {
          "User-Agent": "Mozilla/5.0 (X11; Linux x86_64) AppleWebKit/537.36 Chrome/120.0.0.0 Safari/537.36",
          "Accept": "text/html,application/xhtml+xml,application/xml;q=0.9,*/*;q=0.8",
          "Accept-Language": "fr-FR,fr;q=0.9",
        },
        redirect: "follow",
      }, 10_000);
      initialCookies = extractCookies(loginPageResp.headers.get("set-cookie"));
    } catch {
      // Ignorer les erreurs de la page de login — on continue sans cookies initiaux
    }

    // ── Étape 2 : soumettre les credentials ──
    // FreePro utilise plusieurs endpoints selon la version du portail.
    // On essaie dans l'ordre les endpoints connus.
    const loginEndpoints = [
      `${FREEPRO_BASE_URL}/api/v1/auth/login`,
      `${FREEPRO_BASE_URL}/api/auth/login`,
      `${FREEPRO_BASE_URL}/account/api/auth/login`,
      `${FREEPRO_BASE_URL}/espace-client/api/auth/login`,
    ];

    let sessionCookies = "";
    let loginSuccess = false;

    for (const endpoint of loginEndpoints) {
      try {
        const loginResp = await fetchWithTimeout(endpoint, {
          method: "POST",
          headers: {
            "Content-Type": "application/json",
            "User-Agent": "Mozilla/5.0 (X11; Linux x86_64) AppleWebKit/537.36 Chrome/120.0.0.0 Safari/537.36",
            "Accept": "application/json, text/plain, */*",
            "Accept-Language": "fr-FR,fr;q=0.9",
            "Cookie": initialCookies,
            "Referer": LOGIN_URL,
            "Origin": FREEPRO_BASE_URL,
            "X-Requested-With": "XMLHttpRequest",
          },
          body: JSON.stringify({ email, password }),
          redirect: "follow",
        }, 10_000);

        if (loginResp.ok || loginResp.status === 302) {
          const newCookies = extractCookies(loginResp.headers.get("set-cookie"));
          sessionCookies = [initialCookies, newCookies].filter(Boolean).join("; ");
          loginSuccess = true;
          break;
        }
      } catch {
        // Essayer le prochain endpoint
        continue;
      }
    }

    // ── Étape 3 : vérifier l'accès à /account/ ──
    // Même si aucun endpoint de login n'a répondu 200, on tente d'accéder à /account/
    // car certaines versions du portail redirigent directement après le formulaire HTML.
    const cookiesToTry = sessionCookies || initialCookies;

    try {
      const accountResp = await fetchWithTimeout(ACCOUNT_URL, {
        method: "GET",
        headers: {
          "User-Agent": "Mozilla/5.0 (X11; Linux x86_64) AppleWebKit/537.36 Chrome/120.0.0.0 Safari/537.36",
          "Accept": "text/html,application/xhtml+xml",
          "Cookie": cookiesToTry,
          "Referer": FREEPRO_BASE_URL,
        },
        redirect: "manual", // Ne pas suivre les redirections pour détecter si on est connecté
      }, 10_000);

      // Si on obtient un 200 ou 304, on est connecté
      if (accountResp.status === 200 || accountResp.status === 304) {
        return { success: true, cookies: cookiesToTry };
      }

      // Si on est redirigé vers la page de login, les credentials sont invalides
      const location = accountResp.headers.get("location") ?? "";
      if (location.includes("connexion") || location.includes("login")) {
        return {
          success: false,
          cookies: "",
          error: "Identifiants FreePro incorrects. Vérifiez votre email et mot de passe.",
        };
      }

      // Redirection vers /account/ elle-même = succès
      if (location.includes("/account")) {
        return { success: true, cookies: cookiesToTry };
      }
    } catch (err: any) {
      if (err.name === "AbortError") {
        return {
          success: false,
          cookies: "",
          error: "Délai d'attente dépassé lors de la connexion au portail FreePro (15s). Vérifiez que le portail est accessible.",
        };
      }
    }

    // Si on arrive ici avec loginSuccess = true, on considère que la connexion a fonctionné
    if (loginSuccess) {
      return { success: true, cookies: sessionCookies };
    }

    return {
      success: false,
      cookies: "",
      error: "Impossible de vérifier la connexion au portail FreePro. Le portail est peut-être inaccessible ou a changé de structure.",
    };
  } catch (err: any) {
    if (err.name === "AbortError") {
      return {
        success: false,
        cookies: "",
        error: "Délai d'attente dépassé lors de la connexion au portail FreePro.",
      };
    }
    return {
      success: false,
      cookies: "",
      error: `Erreur réseau lors de la connexion : ${err.message}`,
    };
  }
}

// ── Récupération de la liste des factures ──────────────────────────────────

/**
 * Récupère la liste des factures disponibles sur le portail FreePro
 */
async function fetchInvoiceList(cookies: string): Promise<FreeproInvoice[]> {
  const endpoints = [
    `${FREEPRO_BASE_URL}/account/api/billing/invoices`,
    `${FREEPRO_BASE_URL}/account/billing/api/invoices`,
    `${FREEPRO_BASE_URL}/api/billing/invoices`,
  ];

  for (const endpoint of endpoints) {
    try {
      const resp = await fetchWithTimeout(endpoint, {
        headers: {
          "Cookie": cookies,
          "Accept": "application/json",
          "User-Agent": "Mozilla/5.0 (X11; Linux x86_64) AppleWebKit/537.36 Chrome/120.0.0.0 Safari/537.36",
          "Referer": BILLING_URL,
          "X-Requested-With": "XMLHttpRequest",
        },
      }, 10_000);

      if (resp.ok) {
        const data = await resp.json();
        const invoices = parseInvoiceList(data);
        if (invoices.length > 0) return invoices;
      }
    } catch {
      continue;
    }
  }

  return [];
}

/**
 * Parse la réponse JSON de l'API de facturation FreePro
 */
function parseInvoiceList(data: any): FreeproInvoice[] {
  const invoices: FreeproInvoice[] = [];
  const items = Array.isArray(data) ? data : (data?.invoices ?? data?.data ?? []);

  for (const item of items) {
    const invoiceNumber = item.ref_piece ?? item.invoiceNumber ?? item.id ?? "";
    const date = item.date ?? item.invoiceDate ?? "";
    const amount = parseFloat(item.total ?? item.amount ?? item.ttc ?? "0");

    if (!invoiceNumber || !date) continue;

    let month = "";
    if (date.includes("-")) {
      const parts = date.split("-");
      if (parts.length >= 2) month = `${parts[1].padStart(2, "0")}/${parts[0]}`;
    } else if (date.includes("/")) {
      const parts = date.split("/");
      if (parts.length >= 3) month = `${parts[1].padStart(2, "0")}/${parts[2]}`;
    }

    if (month) invoices.push({ invoiceNumber, date, amount, month });
  }

  return invoices;
}

/**
 * Télécharge le CSV d'une facture FreePro
 */
async function downloadInvoiceCsv(cookies: string, invoiceNumber: string): Promise<Buffer | null> {
  try {
    const csvUrl = `${FREEPRO_BASE_URL}/account/invoice/${invoiceNumber}/primary_csv`;
    const resp = await fetchWithTimeout(csvUrl, {
      headers: {
        "Cookie": cookies,
        "Accept": "text/csv,application/csv,*/*",
        "User-Agent": "Mozilla/5.0 (X11; Linux x86_64) AppleWebKit/537.36 Chrome/120.0.0.0 Safari/537.36",
        "Referer": BILLING_URL,
      },
      redirect: "follow",
    });

    if (!resp.ok) return null;
    const arrayBuffer = await resp.arrayBuffer();
    return Buffer.from(arrayBuffer);
  } catch {
    return null;
  }
}

// ── Test de connexion ──────────────────────────────────────────────────────

/**
 * Teste la connexion au portail FreePro avec les credentials fournis.
 *
 * Retourne toujours un résultat dans les 20 secondes maximum.
 */
export async function testFreeproConnection(
  email: string,
  password: string
): Promise<{ success: boolean; message: string }> {
  // Validation basique des entrées
  if (!email || !email.includes("@")) {
    return { success: false, message: "Adresse email invalide." };
  }
  if (!password || password.length < 3) {
    return { success: false, message: "Mot de passe trop court." };
  }

  try {
    const loginResult = await loginToFreePro(email, password);

    if (!loginResult.success) {
      return {
        success: false,
        message: loginResult.error ?? "Échec de connexion au portail FreePro.",
      };
    }

    // Tenter de récupérer la liste des factures pour enrichir le message
    try {
      const invoices = await fetchInvoiceList(loginResult.cookies);
      if (invoices.length > 0) {
        return {
          success: true,
          message: `Connexion réussie. ${invoices.length} facture(s) disponible(s) dans l'espace client.`,
        };
      }
    } catch {
      // Pas grave si on ne peut pas lister les factures
    }

    return {
      success: true,
      message: "Connexion au portail FreePro réussie. Les identifiants sont valides.",
    };
  } catch (err: any) {
    return {
      success: false,
      message: `Erreur inattendue lors du test de connexion : ${err.message}`,
    };
  }
}

// ── Import automatique ─────────────────────────────────────────────────────

/**
 * Exécute la récupération automatique des factures FreePro pour un utilisateur.
 */
export async function runFreeproAutoImport(userId: number): Promise<AutoImportResult> {
  const result: AutoImportResult = {
    success: false,
    imported: 0,
    skipped: 0,
    errors: [],
    message: "",
  };

  // 1. Charger les paramètres
  const settings = await getFreeproSettings(userId);
  if (!settings) {
    result.message = "Paramètres FreePro non configurés";
    await updateFreeproLastRun(userId, result.message, 0, false);
    return result;
  }

  if (!settings.loginEmail || !settings.loginPassword) {
    result.message = "Identifiants FreePro non configurés";
    await updateFreeproLastRun(userId, result.message, 0, false);
    return result;
  }

  // 2. Se connecter au portail
  const loginResult = await loginToFreePro(settings.loginEmail, settings.loginPassword);
  if (!loginResult.success) {
    result.message = loginResult.error ?? "Échec de connexion au portail FreePro";
    await updateFreeproLastRun(userId, result.message, 0, false);
    return result;
  }

  const { cookies } = loginResult;

  // 3. Récupérer la liste des factures
  const availableInvoices = await fetchInvoiceList(cookies);

  if (availableInvoices.length === 0) {
    result.message = "Aucune facture disponible via l'API du portail FreePro. La récupération automatique nécessite que les factures soient accessibles via l'API interne du portail.";
    await updateFreeproLastRun(userId, result.message, 0, false);
    return result;
  }

  // 4. Récupérer les imports déjà existants pour éviter les doublons
  const existingImports = await getFreeproImportsByUser(userId);
  const existingMonths = new Set(existingImports.map((i) => i.moisLabel));

  // 5. Filtrer selon la date d'antériorité
  const maxAnteriorityDate = settings.maxAnteriority
    ? new Date(settings.maxAnteriority * 1000)
    : null;

  const toImport = availableInvoices.filter((inv) => {
    if (existingMonths.has(inv.month)) {
      result.skipped++;
      return false;
    }
    if (maxAnteriorityDate) {
      const invDate = new Date(inv.date);
      if (invDate < maxAnteriorityDate) {
        result.skipped++;
        return false;
      }
    }
    return true;
  });

  if (toImport.length === 0) {
    result.success = true;
    result.message = `Aucune nouvelle facture à importer (${result.skipped} déjà importée(s))`;
    await updateFreeproLastRun(userId, result.message, 0, true);
    return result;
  }

  // 6. Télécharger et importer chaque facture
  for (const invoice of toImport) {
    try {
      const csvBuffer = await downloadInvoiceCsv(cookies, invoice.invoiceNumber);

      if (!csvBuffer || csvBuffer.length === 0) {
        result.errors.push(`Impossible de télécharger le CSV pour la facture ${invoice.invoiceNumber}`);
        continue;
      }

      const fileName = `Facture_FreePro_${invoice.invoiceNumber}.csv`;
      const processed = processFreeproExcel(csvBuffer, invoice.month, fileName);

      await createFreeproImport(
        {
          userId,
          moisLabel: processed.moisLabel,
          annee: processed.annee,
          mois: processed.mois,
          refPiece: processed.refPiece ?? null,
          fileName,
          nbLignes: processed.nbLignes,
          totalTtc: processed.totalTtc.toFixed(2),
        },
        processed.lines.map((l) => ({
          structure: l.structure ?? null,
          type: l.type,
          montantCentimes: Math.round(l.montant * 100),
        }))
      );

      result.imported++;
    } catch (err: any) {
      result.errors.push(`Erreur lors de l'import de ${invoice.invoiceNumber} : ${err.message}`);
    }
  }

  // 7. Mettre à jour le statut
  result.success = result.imported > 0 || (toImport.length === 0 && result.errors.length === 0);
  if (result.errors.length > 0) {
    result.message = `${result.imported} facture(s) importée(s), ${result.errors.length} erreur(s) : ${result.errors.join("; ")}`;
  } else {
    result.message = `${result.imported} facture(s) importée(s) avec succès`;
  }

  await updateFreeproLastRun(userId, result.message, result.imported, result.success);
  return result;
}

// ── Scheduler en mémoire ───────────────────────────────────────────────────

const activeJobs = new Map<number, NodeJS.Timeout>();

export function startFreeproAutoJob(userId: number, frequencyMs: number): void {
  stopFreeproAutoJob(userId);
  const interval = setInterval(async () => {
    try {
      await runFreeproAutoImport(userId);
    } catch (err: any) {
      console.error(`[FreePro Auto] Erreur job userId=${userId}:`, err.message);
    }
  }, frequencyMs);
  activeJobs.set(userId, interval);
  console.log(`[FreePro Auto] Job démarré pour userId=${userId}, fréquence=${frequencyMs}ms`);
}

export function stopFreeproAutoJob(userId: number): void {
  const interval = activeJobs.get(userId);
  if (interval) {
    clearInterval(interval);
    activeJobs.delete(userId);
    console.log(`[FreePro Auto] Job arrêté pour userId=${userId}`);
  }
}

export function frequencyToMs(frequency: string): number {
  switch (frequency) {
    case "daily":   return 24 * 60 * 60 * 1000;
    case "weekly":  return 7 * 24 * 60 * 60 * 1000;
    case "monthly": return 30 * 24 * 60 * 60 * 1000;
    default:        return 0;
  }
}