\n \n \n
\n $\"mAI$ \n
Nouveau ticket de support

RÉFÉRENCE : ${ticketRef}
\n\n \n
Un utilisateur vient de soumettre un nouveau ticket sur la plateforme mAI.
\n \n \n
\n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n
Demandeur :	\n ${escapeHtml(ticket.user_name)} \n (${\n escapeHtml(ticket.user_email)\n })\n ${\n ticket.user_tier\n ? `${\n escapeHtml(ticket.user_tier)\n }`\n : \"\"\n }\n
Projet :	${\n escapeHtml(ticket.project)\n }
Section :	${\n escapeHtml(ticket.category)\n }
Priorité :	\n \n ${priorityInfo.label}\n \n
\n\n \n
Objet de la demande :
${\n escapeHtml(ticket.title)\n }

\n ${safeDescription}\n
\n\n \n
\n \n → Répondre au ticket #${\n ticket.ticket_number || ticket.id.slice(0, 6)\n }\n \n
\n\n
\n Vous pouvez également écrire directement au demandeur : \n \n ${escapeHtml(ticket.user_email)}\n \n
\n\n \n
Cet e-mail automatique est destiné à l'administration du support mAI.
\n\n
\n \n \n `;\n\n return await sendHtmlEmail(adminEmail, subject, html);\n}\n\n/**\n * Envoie une notification par e-mail à l'utilisateur (ou à l'admin) lors d'une action ou d'une réponse.\n */\nexport async function sendSupportTicketUpdateEmail({\n ticket,\n recipientEmail,\n recipientName,\n message,\n newStatus,\n authorRole,\n appUrl = \"https://m-ai.fr\",\n isAiGenerated,\n}: {\n ticket: SupportTicketEmailPayload;\n recipientEmail: string;\n recipientName: string;\n message: string;\n newStatus?: string;\n authorRole: \"admin\" | \"user\" | \"system\";\n appUrl?: string;\n isAiGenerated?: boolean;\n}) {\n const ticketRef = ticket.ticket_number\n ? `#TICK-${ticket.ticket_number}`\n : `#${ticket.id.slice(0, 8)}`;\n const isFromAdmin = authorRole === \"admin\";\n const subject = isFromAdmin\n ? `[Support mAI] Réponse à votre ticket ${ticketRef} : ${ticket.title}`\n : `[Support mAI] Nouveau message sur le ticket ${ticketRef}`;\n\n const directLink = `${\n appUrl.replace(/\\/$/, \"\")\n }/support/tickets/${ticket.id}`;\n const safeMessage = escapeHtml(message).replace(/\\n/g, \"
\");\n\n const html = `\n \n \n \n \n \n ${escapeHtml(subject)}\n \n \n
\n \n \n
\n $\"mAI$ \n
\n ${isFromAdmin ? \"Réponse de l'Équipe Support\" : \"Nouveau message\"}\n

TICKET ${ticketRef} • ${\n escapeHtml(ticket.title)\n }
\n\n \n
Bonjour ${\n escapeHtml(recipientName)\n },
\n \n
\n ${\n isFromAdmin\n ? \"Un membre de l'équipe technique de mAI a répondu à votre demande :\"\n : \"Un nouveau message a été posté sur le ticket :\"\n }\n
\n \n \n
\n ${safeMessage}\n
\n\n ${\n isAiGenerated || ticket.isAiGenerated\n ? `\n
\n IA\n Contenu créé avec l'assistance de l'IA — ce message a été généré avec l'aide de l'IA et relu par l'équipe mAI.\n
\n `\n : \"\"\n }\n\n ${\n newStatus\n ? `\n
\n Mise à jour de statut : Le ticket est désormais noté comme ${\n escapeHtml(newStatus)\n }.\n
\n `\n : \"\"\n }\n\n \n
\n \n Voir le fil de discussion et répondre\n \n
\n\n
\n Vous pouvez à tout moment suivre l'état de l'ensemble de vos demandes sur votre \n Espace Support mAI.\n
\n\n \n
mDevsLabs • Solutions d'Intelligence Artificielle Souveraines
\n\n
\n \n \n `;\n\n return await sendHtmlEmail(recipientEmail, subject, html);\n}",[151],"12a17dc51112a8e750c296bc97186710c44b6d01ff0ac8e114a52f94255c5791","8e336185-f4bb-4cbb-8529-db37165052ee","e9725edc-9c6a-11f1-8111-1607ee4eb77e",119,["D",1787929713599],9,"import nodemailer from \"npm:nodemailer@^7.0.6\";\n\nfunction escapeHtml(str: string): string {\n return String(str)\n .replace(/&/g, \"&\")\n .replace(//g, \">\")\n .replace(/\"/g, \""\")\n .replace(/'/g, \"'\");\n}\n\nfunction getEnv(key: string): string | undefined {\n if (typeof process !== \"undefined\" && process.env && process.env[key]) {\n return process.env[key];\n }\n // @ts-ignore\n if (typeof Deno !== \"undefined\" && Deno.env && Deno.env.get) {\n // @ts-ignore\n return Deno.env.get(key);\n }\n return undefined;\n}\n\nexport async function sendVerificationEmail(\n email: string,\n code: string,\n action: string,\n extraInfo?: any,\n) {\n // Log du code pour développement / debugging\n const maskedEmail = email.replace(/(.{2}).*(@.*)/, \"$1***$2\");\n console.log(\n `[EMAIL] action=${action} to=${maskedEmail} hasCode=${\n Boolean(code)\n } code=${code}`,\n );\n\n let subject = \"Notification - mAI\";\n let title = \"Notification\";\n let textContent = \"\";\n let showCode = code ? true : false;\n\n switch (action) {\n case \"register\":\n subject = \"Vérifiez votre adresse e-mail - mAI\";\n title = \"Vérification d'inscription\";\n textContent =\n \"Voici votre code de vérification à 6 chiffres pour votre compte mAI :\";\n break;\n case \"login\":\n subject = \"Code de vérification de connexion - mAI\";\n title = \"Vérification de connexion\";\n textContent =\n \"Voici votre code de vérification à 6 chiffres pour votre compte mAI :\";\n break;\n case \"verify_new_email\":\n subject = \"Vérification de votre nouvelle adresse e-mail - mAI\";\n title = \"Changement d'e-mail\";\n textContent =\n \"Voici le code de vérification pour confirmer votre nouvelle adresse e-mail :\";\n break;\n case \"delete_account\":\n subject = \"Code de suppression de compte - mAI\";\n title = \"Suppression du compte\";\n textContent =\n \"Vous avez demandé la suppression de votre compte. Voici votre code à 8 chiffres :\";\n break;\n case \"subscription_unlocked\": {\n const tierUnlocked = escapeHtml(extraInfo?.tier || \"Pro\");\n subject = `Merci d'avoir souscrit au forfait ${tierUnlocked} ! - mAI`;\n title = `Merci d'avoir souscrit au forfait ${tierUnlocked} !`;\n showCode = false;\n textContent =\n `Nous vous remercions chaleureusement pour votre souscription au forfait ${tierUnlocked} sur mAI !

\n Votre compte bénéficie dès maintenant de vos nouveaux quotas étendus pour l'ensemble de vos applications et clés d'API (tokens mAI, requêtes API et stockage Cloud).

\n Toute l'équipe mDevsLabs vous remercie pour votre confiance et vous souhaite une excellente expérience créative et productive avec mAI.`;\n break;\n }\n case \"new_login\": {\n subject = \"Nouvelle connexion détectée - mAI\";\n title = \"Alerte de sécurité\";\n showCode = false;\n const device = escapeHtml(extraInfo?.device || \"Appareil inconnu\");\n const location = escapeHtml(extraInfo?.location || \"Lieu inconnu\");\n textContent =\n `Une nouvelle connexion à votre compte mAI a été détectée depuis :

\n Appareil : ${device}
\n Localisation : ${location}

\n Si vous êtes à l'origine de cette connexion, aucune action n'est requise. Sinon, modifiez immédiatement votre mot de passe et déconnectez cet appareil.`;\n break;\n }\n }\n\n const html = `\n \n \n \n \n \n \n \n
\n \n \n
\n $\"mAI$ \n
${title}

\n\n \n
Bonjour,
${textContent}
\n \n ${\n showCode\n ? `\n \n
\n ${escapeHtml(code)}\n
Code unique • Expire dans 10 minutes
\n `\n : \"\"\n }\n\n
Si vous n'êtes pas à l'origine de cette demande, vous pouvez l'ignorer ou sécuriser votre compte.
\n\n \n
Cet e-mail automatique a été envoyé de manière sécurisée.
\n\n
\n \n \n `;\n\n await sendHtmlEmail(email, subject, html);\n}\n\n// ─────────────────────────────────────────────\n// Envoi d'e-mail générique avec fallback\n// ─────────────────────────────────────────────\nexport async function sendHtmlEmail(\n to: string,\n subject: string,\n html: string,\n): Promise {\n // 1. Google Apps Script (Recommandé)\n const googleScriptsUrl = getEnv(\"GOOGLE_SCRIPTS_URL\") ||\n getEnv(\"GOOGLE_SCRIPT_URL\");\n const googleScriptSecret = getEnv(\"GOOGLE_SCRIPTS_SECRET\") ||\n getEnv(\"GOOGLE_SCRIPT_SECRET\");\n\n if (googleScriptsUrl && googleScriptSecret) {\n try {\n const res = await fetch(googleScriptsUrl, {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({\n secret: googleScriptSecret,\n to,\n subject,\n htmlBody: html,\n body: \"Veuillez activer l'affichage HTML pour lire cet e-mail mAI.\",\n }),\n });\n\n if (res.ok) {\n const data = await res.json();\n if (data.success) {\n const maskedTo = to.replace(/(.{2}).*(@.*)/, \"$1***$2\");\n console.log(`[EMAIL] Google Apps Script OK to=${maskedTo}`);\n return true;\n } else {\n console.error(\"Erreur de retour Google Apps Script :\", data.error);\n }\n } else {\n console.error(\n \"Erreur HTTP Google Apps Script :\",\n res.status,\n res.statusText,\n );\n }\n } catch (err: any) {\n console.error(\n \"Erreur envoi via Google Apps Script :\",\n err?.message || err,\n );\n }\n }\n\n // 2. Fallback Gmail SMTP via Nodemailer\n const gmailUser = getEnv(\"GMAIL_USER\") || \"tusseaumathias85@gmail.com\";\n const gmailAppPass = getEnv(\"GMAIL_APP_PASSWORD\");\n\n if (gmailUser && gmailAppPass) {\n try {\n const transporter = nodemailer.createTransport({\n auth: {\n pass: gmailAppPass,\n user: gmailUser,\n },\n service: \"gmail\",\n });\n\n await transporter.sendMail({\n from: `\"mAI Support\" <${gmailUser}>`,\n html,\n subject,\n to,\n });\n\n const maskedTo = to.replace(/(.{2}).*(@.*)/, \"$1***$2\");\n console.log(`[EMAIL] Gmail SMTP OK to=${maskedTo}`);\n return true;\n } catch (err: any) {\n console.error(\"Erreur envoi Gmail SMTP :\", err?.message || err);\n }\n } else {\n console.warn(\n \"[EMAIL] Ni Google Apps Script ni Gmail SMTP configurés pour l'envoi.\",\n );\n }\n\n return false;\n}\n\n// ─────────────────────────────────────────────\n// Notifications pour le Support & Signalement de bugs\n// ─────────────────────────────────────────────\nexport interface SupportTicketEmailPayload {\n id: string;\n ticket_number?: number | string;\n user_id: string;\n user_email: string;\n user_name: string;\n user_tier?: string;\n title: string;\n description: string;\n category: string;\n project: string;\n priority: string;\n status?: string;\n created_at?: string;\n}\n\nconst PRIORITY_COLORS: Record<\n string,\n { label: string; bg: string; text: string; border: string }\n> = {\n urgent: {\n label: \"Critique / Urgent\",\n bg: \"rgba(239, 68, 68, 0.15)\",\n text: \"#ef4444\",\n border: \"rgba(239, 68, 68, 0.4)\",\n },\n high: {\n label: \"Haute\",\n bg: \"rgba(249, 115, 22, 0.15)\",\n text: \"#f97316\",\n border: \"rgba(249, 115, 22, 0.4)\",\n },\n medium: {\n label: \"Normale\",\n bg: \"rgba(16, 185, 129, 0.15)\",\n text: \"#10b981\",\n border: \"rgba(16, 185, 129, 0.4)\",\n },\n low: {\n label: \"Faible\",\n bg: \"rgba(59, 130, 246, 0.15)\",\n text: \"#3b82f6\",\n border: \"rgba(59, 130, 246, 0.4)\",\n },\n};\n\n/**\n * Envoie un e-mail à mathias.tss2012@gmail.com pour lui présenter le nouveau ticket créé.\n */\nexport async function sendSupportTicketCreatedEmail({\n ticket,\n appUrl = \"https://m-ai.fr\",\n}: {\n ticket: SupportTicketEmailPayload;\n appUrl?: string;\n}) {\n const adminEmail = \"mathias.tss2012@gmail.com\";\n const ticketRef = ticket.ticket_number\n ? `#TICK-${ticket.ticket_number}`\n : `#${ticket.id.slice(0, 8)}`;\n const subject = `[Support mAI] Nouveau ticket ${ticketRef} : ${ticket.title}`;\n\n const priorityInfo = PRIORITY_COLORS[ticket.priority.toLowerCase()] ||\n PRIORITY_COLORS.medium;\n const directLink = `${\n appUrl.replace(/\\/$/, \"\")\n }/support/tickets/${ticket.id}`;\n const safeDescription = escapeHtml(ticket.description).replace(/\\n/g, \"
\");\n\n const html = `\n \n \n \n \n \n ${escapeHtml(subject)}\n \n \n
\n \n \n
\n $\"mAI$ \n
Nouveau ticket de support

RÉFÉRENCE : ${ticketRef}
\n\n \n
Un utilisateur vient de soumettre un nouveau ticket sur la plateforme mAI.
\n \n \n
\n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n
Demandeur :	\n ${escapeHtml(ticket.user_name)} \n (${\n escapeHtml(ticket.user_email)\n })\n ${\n ticket.user_tier\n ? `${\n escapeHtml(ticket.user_tier)\n }`\n : \"\"\n }\n
Projet :	${\n escapeHtml(ticket.project)\n }
Section :	${\n escapeHtml(ticket.category)\n }
Priorité :	\n \n ${priorityInfo.label}\n \n
\n\n \n
Objet de la demande :
${\n escapeHtml(ticket.title)\n }

\n ${safeDescription}\n
\n\n \n
\n \n 👉 Répondre au ticket #${\n ticket.ticket_number || ticket.id.slice(0, 6)\n }\n \n
\n\n
\n Vous pouvez également écrire directement au demandeur : \n \n ${escapeHtml(ticket.user_email)}\n \n
\n\n \n
Cet e-mail automatique est destiné à l'administration du support mAI.
\n\n
\n \n \n `;\n\n return await sendHtmlEmail(adminEmail, subject, html);\n}\n\n/**\n * Envoie une notification par e-mail à l'utilisateur (ou à l'admin) lors d'une action ou d'une réponse.\n */\nexport async function sendSupportTicketUpdateEmail({\n ticket,\n recipientEmail,\n recipientName,\n message,\n newStatus,\n authorRole,\n appUrl = \"https://m-ai.fr\",\n}: {\n ticket: SupportTicketEmailPayload;\n recipientEmail: string;\n recipientName: string;\n message: string;\n newStatus?: string;\n authorRole: \"admin\" | \"user\" | \"system\";\n appUrl?: string;\n}) {\n const ticketRef = ticket.ticket_number\n ? `#TICK-${ticket.ticket_number}`\n : `#${ticket.id.slice(0, 8)}`;\n const isFromAdmin = authorRole === \"admin\";\n const subject = isFromAdmin\n ? `[Support mAI] Réponse à votre ticket ${ticketRef} : ${ticket.title}`\n : `[Support mAI] Nouveau message sur le ticket ${ticketRef}`;\n\n const directLink = `${\n appUrl.replace(/\\/$/, \"\")\n }/support/tickets/${ticket.id}`;\n const safeMessage = escapeHtml(message).replace(/\\n/g, \"
\");\n\n const html = `\n \n \n \n \n \n ${escapeHtml(subject)}\n \n \n
\n \n \n
\n $\"mAI$ \n
\n ${isFromAdmin ? \"Réponse de l'Équipe Support\" : \"Nouveau message\"}\n

TICKET ${ticketRef} • ${\n escapeHtml(ticket.title)\n }
\n\n \n
Bonjour ${\n escapeHtml(recipientName)\n },
\n \n
\n ${\n isFromAdmin\n ? \"Un membre de l'équipe technique de mAI a répondu à votre demande :\"\n : \"Un nouveau message a été posté sur le ticket :\"\n }\n
\n \n \n
\n ${safeMessage}\n
\n\n ${\n newStatus\n ? `\n
\n Mise à jour de statut : Le ticket est désormais noté comme ${\n escapeHtml(newStatus)\n }.\n
\n `\n : \"\"\n }\n\n \n
\n \n Voir le fil de discussion et répondre\n \n
\n\n
\n Vous pouvez à tout moment suivre l'état de l'ensemble de vos demandes sur votre \n Espace Support mAI.\n
\n\n \n
mDevsLabs • Solutions d'Intelligence Artificielle Souveraines
\n\n
\", \"translation\": \"\"} — sans guillemets markdown ni commentaire.';\n        const raw = await MAIAgentFleet.callOpenRouter(userId, system, content);\n        if (!raw) {\n          return c.json({\n            error: \"Traduction indisponible (DeepL et mAI injoignables).\",\n          }, 502);\n        }\n        await debitWeeklyTokens(sql, userId, content.length + raw.length);\n        const parsed = extractJsonObject(raw);\n        if (\n          parsed && typeof parsed.translation === \"string\" &&\n          parsed.translation.trim()\n        ) {\n          detected = String(parsed.detected_language || \"\").trim();\n          translation = cleanLlmText(parsed.translation);\n          if (\n            parsed.target_language &&\n            String(parsed.target_language).toLowerCase().includes(\"anglais\")\n          ) {\n            effectiveTargetLang = \"EN-US\";\n          }\n        } else {\n          // Repli : la réponse entière est la traduction\n          translation = cleanLlmText(raw);\n        }\n        provider = \"mai\";\n        if (!translation) return c.json({ error: \"Traduction vide.\" }, 502);\n      }\n\n      // 4. Mise en cache (traductions exactes réutilisables, coût amorti)\n      if (!sameLanguage && translation && translation !== content) {\n        try {\n          if (postId) {\n            await sql`\n              INSERT INTO post_translations (post_id, target_lang, detected_language, translation, provider)\n              VALUES (${postId}::uuid, ${effectiveTargetLang}, ${detected}, ${translation}, ${provider})\n              ON CONFLICT (post_id, target_lang) DO UPDATE SET translation = EXCLUDED.translation, detected_language = EXCLUDED.detected_language, provider = EXCLUDED.provider\n            `;\n          } else {\n            await sql`\n              INSERT INTO comment_translations (comment_id, target_lang, detected_language, translation, provider)\n              VALUES (${commentId}::uuid, ${effectiveTargetLang}, ${detected}, ${translation}, ${provider})\n              ON CONFLICT (comment_id, target_lang) DO UPDATE SET translation = EXCLUDED.translation, detected_language = EXCLUDED.detected_language, provider = EXCLUDED.provider\n            `;\n          }\n        } catch {}\n      }\n\n      return c.json({\n        success: true,\n        translation,\n        detected_language: detected,\n        target_lang: effectiveTargetLang,\n        provider,\n        same_language: sameLanguage,\n        cached: false,\n      });\n    } catch (err: any) {\n      console.error(\"[translate] Translate error:\", err);\n      return c.json({ error: err?.message || \"Erreur de traduction.\" }, 500);\n    }\n  };\n\n  registerMulti(\"post\", [\n    \"/api/vibe/translate\",\n    \"/vibe/translate\",\n    \"/v1/translate\",\n    \"/translate\",\n  ], handleTranslate);\n}",[620],"88b73019-c4b9-4677-93d1-46ef805aa3d5",278,["D",1789145672482],"import type { Hono } from \"npm:hono@4\";\nimport {\n  extractTierFromApiKey,\n  extractToken,\n  getDb,\n  getTierStorageLimitBytes,\n  verifyToken,\n} from \"./config.ts\";\n\nexport interface StorageNode {\n  id: number;\n  endpoint: string;\n  region: string;\n  accessKeyId: string;\n  secretAccessKey: string;\n  bucket: string;\n  publicUrl: string;\n}\n\nfunction cleanUrl(url: string, removeDefaultPort = true): string {\n  let cleaned = (url || \"\").trim();\n  if (cleaned.endsWith(\"/\")) {\n    cleaned = cleaned.slice(0, -1);\n  }\n  if (removeDefaultPort) {\n    // Normalise https://domaine.com:443 -> https://domaine.com pour des URLs publiques propres\n    cleaned = cleaned.replace(\n      /^https:\\/\\/([^/:]+):443(\\/.*)?$/,\n      \"https://$1$2\",\n    );\n    cleaned = cleaned.replace(/^http:\\/\\/([^/:]+):80(\\/.*)?$/, \"http://$1$2\");\n  }\n  return cleaned;\n}\n\n/**\n * 10 buckets Z1 Storage par défaut en fallback (mai-storage-1 à mai-storage-10)\n */\nexport const DEFAULT_Z1_FALLBACK_BUCKETS = [\n  \"mai-storage-1\",\n  \"mai-storage-2\",\n  \"mai-storage-3\",\n  \"mai-storage-4\",\n  \"mai-storage-5\",\n  \"mai-storage-6\",\n  \"mai-storage-7\",\n  \"mai-storage-8\",\n  \"mai-storage-9\",\n  \"mai-storage-10\",\n];\n\nexport const TOTAL_STORAGE_NODES_COUNT = 10;\n\n/**\n * Récupère la liste des nœuds de stockage Z1 Storage / S3 configurés.\n * Supporte jusqu'à 10 comptes/buckets distincts (S3_BUCKET_1..10 / Z1_BUCKET_1..10) pour multiplier l'espace,\n * ou une liste séparée par des virgules (S3_BUCKETS / Z1_BUCKETS),\n * ou un pool de 10 buckets Z1 Storage (mai-storage-1 à mai-storage-10) en fallback automatique.\n */\nexport function getStorageNodes(): StorageNode[] {\n  const nodes: StorageNode[] = [];\n\n  const baseAccessKey = Deno.env.get(\"S3_ACCESS_KEY_ID\") ||\n    Deno.env.get(\"Z1_ACCESS_KEY_ID\") ||\n    \"\";\n  const baseSecretKey = Deno.env.get(\"S3_SECRET_ACCESS_KEY\") ||\n    Deno.env.get(\"Z1_SECRET_ACCESS_KEY\") ||\n    \"\";\n  const baseRawEndpoint = Deno.env.get(\"S3_ENDPOINT\") ||\n    Deno.env.get(\"Z1_ENDPOINT\") ||\n    \"https://s3.z1storage.com\";\n  const baseEndpoint = cleanUrl(baseRawEndpoint);\n  const baseRegion = Deno.env.get(\"S3_REGION\") ||\n    Deno.env.get(\"Z1_REGION\") ||\n    \"auto\";\n  const baseBucket = Deno.env.get(\"S3_BUCKET\") ||\n    Deno.env.get(\"Z1_BUCKET\") ||\n    \"mai-storage-1\";\n  const basePublicUrl = Deno.env.get(\"S3_PUBLIC_URL\") ||\n    Deno.env.get(\"Z1_PUBLIC_URL\");\n\n  // 1. Détection des configurations individuelles S3_BUCKET_1 à S3_BUCKET_10 (ou Z1_BUCKET_1 à 10)\n  for (let i = 1; i <= TOTAL_STORAGE_NODES_COUNT; i++) {\n    const bucket = Deno.env.get(`S3_BUCKET_${i}`) ||\n      Deno.env.get(`S3_BUCKET${i}`) ||\n      Deno.env.get(`Z1_BUCKET_${i}`) ||\n      Deno.env.get(`Z1_BUCKET${i}`);\n    const accessKeyId = Deno.env.get(`S3_ACCESS_KEY_ID_${i}`) ||\n      Deno.env.get(`S3_ACCESS_KEY_ID${i}`) ||\n      Deno.env.get(`Z1_ACCESS_KEY_ID_${i}`) ||\n      Deno.env.get(`Z1_ACCESS_KEY_ID${i}`) ||\n      baseAccessKey;\n    const secretAccessKey = Deno.env.get(`S3_SECRET_ACCESS_KEY_${i}`) ||\n      Deno.env.get(`S3_SECRET_ACCESS_KEY${i}`) ||\n      Deno.env.get(`Z1_SECRET_ACCESS_KEY_${i}`) ||\n      Deno.env.get(`Z1_SECRET_ACCESS_KEY${i}`) ||\n      baseSecretKey;\n    const rawEndpoint = Deno.env.get(`S3_ENDPOINT_${i}`) ||\n      Deno.env.get(`S3_ENDPOINT${i}`) ||\n      Deno.env.get(`Z1_ENDPOINT_${i}`) ||\n      Deno.env.get(`Z1_ENDPOINT${i}`) ||\n      baseEndpoint;\n    const endpoint = cleanUrl(rawEndpoint);\n    const region = Deno.env.get(`S3_REGION_${i}`) ||\n      Deno.env.get(`S3_REGION${i}`) ||\n      Deno.env.get(`Z1_REGION_${i}`) ||\n      Deno.env.get(`Z1_REGION${i}`) ||\n      baseRegion;\n    const rawPublicUrl = Deno.env.get(`S3_PUBLIC_URL_${i}`) ||\n      Deno.env.get(`S3_PUBLIC_URL${i}`) ||\n      Deno.env.get(`Z1_PUBLIC_URL_${i}`) ||\n      Deno.env.get(`Z1_PUBLIC_URL${i}`);\n\n    let publicUrl = \"\";\n    if (rawPublicUrl) {\n      publicUrl = cleanUrl(rawPublicUrl);\n    } else if (basePublicUrl) {\n      publicUrl = `${cleanUrl(basePublicUrl)}/${bucket}`;\n    } else if (bucket) {\n      publicUrl = `${endpoint}/${bucket}`;\n    }\n\n    if (bucket && accessKeyId && secretAccessKey) {\n      nodes.push({\n        id: i,\n        endpoint,\n        region,\n        accessKeyId,\n        secretAccessKey,\n        bucket,\n        publicUrl: publicUrl || `${endpoint}/${bucket}`,\n      });\n    }\n  }\n\n  // 2. Si S3_BUCKETS ou Z1_BUCKETS (liste séparée par des virgules) est configuré\n  if (nodes.length === 0) {\n    const bucketsList = Deno.env.get(\"S3_BUCKETS\") ||\n      Deno.env.get(\"Z1_BUCKETS\");\n    if (bucketsList) {\n      const bucketNames = bucketsList\n        .split(\",\")\n        .map((b) => b.trim())\n        .filter(Boolean);\n\n      bucketNames.forEach((bucket, idx) => {\n        const id = idx + 1;\n        let publicUrl = \"\";\n        if (basePublicUrl) {\n          publicUrl = `${cleanUrl(basePublicUrl)}/${bucket}`;\n        } else {\n          publicUrl = `${baseEndpoint}/${bucket}`;\n        }\n\n        nodes.push({\n          id,\n          endpoint: baseEndpoint,\n          region: baseRegion,\n          accessKeyId: baseAccessKey,\n          secretAccessKey: baseSecretKey,\n          bucket,\n          publicUrl,\n        });\n      });\n    }\n  }\n\n  // 3. Fallback automatique : 10 buckets Z1 Storage (mai-storage-1 à mai-storage-10)\n  // Si moins de 10 nœuds sont configurés, on complète avec les 10 buckets Z1 Storage en fallback\n  if (nodes.length < TOTAL_STORAGE_NODES_COUNT) {\n    const fallbackEnvList = (\n      Deno.env.get(\"Z1_FALLBACK_BUCKETS\") ||\n      Deno.env.get(\"S3_FALLBACK_BUCKETS\") ||\n      \"\"\n    )\n      .split(\",\")\n      .map((b) => b.trim())\n      .filter(Boolean);\n\n    for (let i = 1; i <= TOTAL_STORAGE_NODES_COUNT; i++) {\n      const exists = nodes.some((n) => n.id === i);\n      if (!exists) {\n        let fallbackBucketName = \"\";\n        if (fallbackEnvList[i - 1]) {\n          fallbackBucketName = fallbackEnvList[i - 1];\n        } else if (i === 1 && baseBucket) {\n          fallbackBucketName = baseBucket;\n        } else if (DEFAULT_Z1_FALLBACK_BUCKETS[i - 1]) {\n          fallbackBucketName = DEFAULT_Z1_FALLBACK_BUCKETS[i - 1];\n        } else {\n          fallbackBucketName = `mai-storage-${i}`;\n        }\n\n        const bucket = Deno.env.get(`S3_BUCKET_${i}`) ||\n          Deno.env.get(`S3_BUCKET${i}`) ||\n          Deno.env.get(`Z1_BUCKET_${i}`) ||\n          Deno.env.get(`Z1_BUCKET${i}`) ||\n          fallbackBucketName;\n\n        const accessKeyId = Deno.env.get(`S3_ACCESS_KEY_ID_${i}`) ||\n          Deno.env.get(`S3_ACCESS_KEY_ID${i}`) ||\n          Deno.env.get(`Z1_ACCESS_KEY_ID_${i}`) ||\n          Deno.env.get(`Z1_ACCESS_KEY_ID${i}`) ||\n          baseAccessKey;\n\n        const secretAccessKey = Deno.env.get(`S3_SECRET_ACCESS_KEY_${i}`) ||\n          Deno.env.get(`S3_SECRET_ACCESS_KEY${i}`) ||\n          Deno.env.get(`Z1_SECRET_ACCESS_KEY_${i}`) ||\n          Deno.env.get(`Z1_SECRET_ACCESS_KEY${i}`) ||\n          baseSecretKey;\n\n        const rawEndpoint = Deno.env.get(`S3_ENDPOINT_${i}`) ||\n          Deno.env.get(`S3_ENDPOINT${i}`) ||\n          Deno.env.get(`Z1_ENDPOINT_${i}`) ||\n          Deno.env.get(`Z1_ENDPOINT${i}`) ||\n          baseEndpoint;\n        const endpoint = cleanUrl(rawEndpoint);\n\n        const region = Deno.env.get(`S3_REGION_${i}`) ||\n          Deno.env.get(`S3_REGION${i}`) ||\n          Deno.env.get(`Z1_REGION_${i}`) ||\n          Deno.env.get(`Z1_REGION${i}`) ||\n          baseRegion;\n\n        const rawPublicUrl = Deno.env.get(`S3_PUBLIC_URL_${i}`) ||\n          Deno.env.get(`S3_PUBLIC_URL${i}`) ||\n          Deno.env.get(`Z1_PUBLIC_URL_${i}`) ||\n          Deno.env.get(`Z1_PUBLIC_URL${i}`);\n\n        let publicUrl = \"\";\n        if (rawPublicUrl) {\n          publicUrl = cleanUrl(rawPublicUrl);\n        } else if (basePublicUrl) {\n          publicUrl = `${cleanUrl(basePublicUrl)}/${bucket}`;\n        } else {\n          publicUrl = `${endpoint}/${bucket}`;\n        }\n\n        nodes.push({\n          id: i,\n          endpoint,\n          region,\n          accessKeyId,\n          secretAccessKey,\n          bucket,\n          publicUrl,\n        });\n      }\n    }\n  }\n\n  // Tri par ID croissant pour ordre déterministe\n  nodes.sort((a, b) => a.id - b.id);\n  return nodes;\n}\n\n/**\n * Retourne la liste ordonnée des nœuds de stockage pour le fallback.\n * Le nœud principal est placé en premier, suivi des autres buckets Z1 Storage en réserve (fallback).\n */\nexport function getFallbackNodes(primaryNode?: StorageNode): StorageNode[] {\n  const allNodes = getStorageNodes();\n  if (!primaryNode) return allNodes;\n  const others = allNodes.filter((n) => n.id !== primaryNode.id);\n  return [primaryNode, ...others];\n}\n\n/**\n * Effectue un upload S3 avec bascule automatique (fallback) sur les 10 nœuds/buckets\n * Z1 Storage configurés si le nœud principal échoue (erreur HTTP 4xx/5xx ou exception réseau).\n */\nexport async function uploadWithFallback(\n  primaryNode: StorageNode,\n  filePath: string,\n  body: any,\n  options: {\n    contentType: string;\n    acl?: string;\n  },\n): Promise<{\n  success: boolean;\n  activeNode: StorageNode;\n  publicUrl: string;\n  error?: string;\n}> {\n  const candidateNodes = getFallbackNodes(primaryNode);\n  let lastError = \"\";\n\n  for (const node of candidateNodes) {\n    try {\n      const s3Client = await buildS3Client(node);\n      const uploadUrl = `${node.endpoint}/${node.bucket}/${filePath}`;\n      const res = await s3Client.fetch(uploadUrl, {\n        body,\n        headers: {\n          \"Content-Type\": options.contentType || \"application/octet-stream\",\n          \"x-amz-acl\": options.acl || \"public-read\",\n        },\n        method: \"PUT\",\n      });\n\n      if (res.ok) {\n        return {\n          activeNode: node,\n          publicUrl: `${node.publicUrl}/${filePath}`,\n          success: true,\n        };\n      }\n\n      lastError = await res.text().catch(() => `HTTP ${res.status}`);\n      console.warn(\n        `[Z1 Storage Fallback] Échec upload sur le bucket \"${node.bucket}\" (node ${node.id}, status ${res.status}): ${lastError}. Bascule sur le bucket suivant...`,\n      );\n    } catch (err: any) {\n      lastError = err?.message || String(err);\n      console.warn(\n        `[Z1 Storage Fallback] Exception réseau sur le bucket \"${node.bucket}\" (node ${node.id}): ${lastError}. Bascule sur le bucket suivant...`,\n      );\n    }\n  }\n\n  return {\n    activeNode: primaryNode,\n    error: lastError,\n    publicUrl: `${primaryNode.publicUrl}/${filePath}`,\n    success: false,\n  };\n}\n\n/**\n * Sélectionne un nœud de stockage dans le pool via un hachage déterministe (sharding équilibré).\n */\nexport function selectStorageNode(seed: string): StorageNode {\n  const nodes = getStorageNodes();\n  if (nodes.length <= 1) return nodes[0];\n\n  let hash = 0;\n  for (let i = 0; i < seed.length; i++) {\n    hash = (hash << 5) - hash + seed.charCodeAt(i);\n    hash |= 0; // Convertit en entier 32 bits\n  }\n  const index = Math.abs(hash) % nodes.length;\n  return nodes[index];\n}\n\n/**\n * Retrouve le nœud de stockage et la clé brute d'un enregistrement existant.\n */\nexport function findStorageNodeForRecord(\n  r2Key: string,\n  fileUrl?: string,\n): { node: StorageNode; rawKey: string } {\n  const nodes = getStorageNodes();\n\n  // 1. Format explicite taggé : node-1:bucket-name:key-path\n  if (r2Key && r2Key.startsWith(\"node-\")) {\n    const parts = r2Key.split(\":\");\n    if (parts.length >= 3) {\n      const nodeId = parseInt(parts[0].replace(\"node-\", \"\"), 10);\n      const found = nodes.find((n) => n.id === nodeId);\n      if (found) {\n        return { node: found, rawKey: parts.slice(2).join(\":\") };\n      }\n    }\n  }\n\n  // 2. Recherche par nom de bucket dans la clé ou l'URL\n  for (const node of nodes) {\n    if (r2Key && r2Key.startsWith(`${node.bucket}/`)) {\n      return { node, rawKey: r2Key.slice(node.bucket.length + 1) };\n    }\n    if (\n      fileUrl &&\n      (fileUrl.includes(`/${node.bucket}/`) ||\n        fileUrl.includes(`://${node.bucket}.`))\n    ) {\n      return { node, rawKey: r2Key };\n    }\n  }\n\n  // 3. Fallback sur le premier nœud\n  return { node: nodes[0], rawKey: r2Key };\n}\n\n/**\n * Crée un client S3 (compatible Z1 Storage / Cloudflare R2 / AWS S3) pour un nœud donné.\n */\nexport async function buildS3Client(node?: StorageNode) {\n  const targetNode = node || getStorageNodes()[0];\n  const { AwsClient } = await import(\"npm:aws4fetch\");\n  return new AwsClient({\n    accessKeyId: targetNode.accessKeyId,\n    region: targetNode.region,\n    secretAccessKey: targetNode.secretAccessKey,\n    service: \"s3\",\n  });\n}\n\n// Aliases de rétro-compatibilité\nexport const buildR2Client = buildS3Client;\nexport function getR2Endpoint(): string {\n  return getStorageNodes()[0].endpoint;\n}\nexport function getR2Bucket(): string {\n  return getStorageNodes()[0].bucket;\n}\nexport function getR2PublicBase(): string {\n  return getStorageNodes()[0].publicUrl;\n}\n\nconst GIB = 1024 * 1024 * 1024;\n\n/** Formate un volume de quota: en Go au-delà de 1 GiB, sinon en Mo. */\nexport function formatQuotaBytes(bytes: number): string {\n  if (bytes >= GIB) {\n    return `${\n      (Math.round((bytes / GIB) * 10) / 10).toString().replace(\".\", \",\")\n    } Go`;\n  }\n  return `${Math.round(bytes / (1024 * 1024))} Mo`;\n}\n\nexport function registerStorageRoutes(app: Hono) {\n  // POST /upload-avatar & /v1/upload-avatar\n  const handleUploadAvatar = async (c: any) => {\n    try {\n      const token = extractToken(c.req.raw);\n      if (!token) {\n        return c.json({ error: \"Non authentifié.\" }, 401);\n      }\n\n      const payload = await verifyToken(token);\n      const userId = payload.sub as string;\n\n      const body = await c.req.parseBody();\n      const file = body[\"avatar\"] || body[\"file\"];\n\n      if (!(file instanceof File) || file.size === 0) {\n        return c.json({ error: \"Fichier invalide ou non fourni.\" }, 400);\n      }\n\n      const MAX_AVATAR_SIZE = 10 * 1024 * 1024;\n      if (file.size > MAX_AVATAR_SIZE) {\n        return c.json({ error: \"Image trop volumineuse (max 10 MB).\" }, 413);\n      }\n      const ALLOWED_IMAGE_TYPES = [\n        \"image/jpeg\",\n        \"image/png\",\n        \"image/webp\",\n        \"image/gif\",\n      ];\n      if (file.type && !ALLOWED_IMAGE_TYPES.includes(file.type)) {\n        return c.json({\n          error: \"Format d'image non supporté (JPEG, PNG, WebP ou GIF requis).\",\n        }, 400);\n      }\n\n      const primaryNode = selectStorageNode(`avatar-${userId}`);\n      const ext = file.name.split(\".\").pop()?.replace(/[^a-zA-Z0-9]/g, \"\") ||\n        \"jpg\";\n      const filename = `avatars/${userId}-${Date.now()}.${ext}`;\n      const arrayBuffer = await file.arrayBuffer();\n\n      const uploadResult = await uploadWithFallback(\n        primaryNode,\n        filename,\n        arrayBuffer,\n        {\n          contentType: file.type || \"image/jpeg\",\n          acl: \"public-read\",\n        },\n      );\n\n      if (!uploadResult.success) {\n        console.error(\n          \"Erreur Z1 Storage S3 (avatar, fallback épuisé):\",\n          uploadResult.error,\n        );\n        return c.json(\n          {\n            error:\n              \"L'upload a échoué sur tous les buckets de stockage. Vérifiez la configuration Z1 Storage (credentials S3) ou réessayez plus tard.\",\n            details: uploadResult.error?.slice(0, 300),\n          },\n          503,\n        );\n      }\n\n      const publicUrl = uploadResult.publicUrl;\n\n      const sql = getDb();\n      await sql`UPDATE users SET avatar_url = ${publicUrl} WHERE id = ${\n        Number(userId)\n      }`;\n      try {\n        await sql`\n          INSERT INTO profiles (user_id, avatar_url)\n          VALUES (${Number(userId)}, ${publicUrl})\n          ON CONFLICT (user_id)\n          DO UPDATE SET avatar_url = ${publicUrl}, updated_at = NOW()\n        `;\n      } catch {}\n\n      return c.json({ avatarUrl: publicUrl, success: true });\n    } catch (err: any) {\n      console.error(\"Upload Avatar Error:\", err);\n      return c.json({ error: \"Erreur serveur lors de l'upload.\" }, 500);\n    }\n  };\n\n  app.post(\"/upload-avatar\", handleUploadAvatar);\n  app.post(\"/v1/upload-avatar\", handleUploadAvatar);\n  app.post(\"/upload-avatar/\", handleUploadAvatar);\n  app.post(\"/v1/upload-avatar/\", handleUploadAvatar);\n\n  // POST /upload-file & /v1/upload-file (sécurisé: auth + validation 10MB + allowlist)\n  const handleUploadFile = async (c: any) => {\n    try {\n      const token = extractToken(c.req.raw);\n      if (!token) {\n        return c.json({ error: \"Non authentifié.\" }, 401);\n      }\n      try {\n        await verifyToken(token);\n      } catch {\n        return c.json({ error: \"Token invalide.\" }, 401);\n      }\n\n      const body = await c.req.parseBody();\n      const file = body[\"file\"];\n\n      if (!(file instanceof File)) {\n        return c.json({ error: \"Fichier invalide ou non fourni.\" }, 400);\n      }\n\n      const MAX_FILE_SIZE = 50 * 1024 * 1024;\n      if (file.size > MAX_FILE_SIZE) {\n        return c.json({ error: \"Fichier trop volumineux (max 50 MB).\" }, 413);\n      }\n      if (file.size === 0) {\n        return c.json({ error: \"Fichier vide.\" }, 400);\n      }\n      const isAllowed = file.type.startsWith(\"image/\") ||\n        file.type.startsWith(\"video/\") ||\n        file.type.startsWith(\"audio/\") ||\n        file.type.startsWith(\"text/\") ||\n        file.type === \"application/pdf\" ||\n        file.type === \"application/json\" ||\n        file.type === \"application/msword\" ||\n        file.type ===\n          \"application/vnd.openxmlformats-officedocument.wordprocessingml.document\" ||\n        file.type === \"application/vnd.ms-excel\" ||\n        file.type ===\n          \"application/vnd.openxmlformats-officedocument.spreadsheetml.sheet\" ||\n        file.type === \"application/vnd.ms-powerpoint\" ||\n        file.type ===\n          \"application/vnd.openxmlformats-officedocument.presentationml.presentation\";\n      if (file.type && !isAllowed) {\n        return c.json({ error: \"Type de fichier non autorisé.\" }, 400);\n      }\n\n      const cleanFilename = file.name.replace(/[^a-zA-Z0-9._-]/g, \"_\");\n      const filename = `uploads/${Date.now()}-${cleanFilename}`;\n\n      const primaryNode = selectStorageNode(cleanFilename);\n      const arrayBuffer = await file.arrayBuffer();\n\n      const uploadResult = await uploadWithFallback(\n        primaryNode,\n        filename,\n        arrayBuffer,\n        {\n          contentType: file.type || \"application/octet-stream\",\n          acl: \"public-read\",\n        },\n      );\n\n      if (!uploadResult.success) {\n        console.error(\n          \"Erreur Z1 Storage S3 (file, fallback épuisé):\",\n          uploadResult.error,\n        );\n        return c.json(\n          {\n            error:\n              \"L'upload a échoué sur tous les buckets de stockage. Vérifiez la configuration Z1 Storage (credentials S3) ou réessayez plus tard.\",\n            details: uploadResult.error?.slice(0, 300),\n          },\n          503,\n        );\n      }\n\n      const publicUrl = uploadResult.publicUrl;\n\n      return c.json({\n        contentType: file.type || \"application/octet-stream\",\n        pathname: filename,\n        url: publicUrl,\n      });\n    } catch (err: any) {\n      console.error(\"Upload File S3 Error:\", err);\n      return c.json({ error: \"Erreur serveur lors de l'upload S3.\" }, 500);\n    }\n  };\n\n  app.post(\"/upload-file\", handleUploadFile);\n  app.post(\"/v1/upload-file\", handleUploadFile);\n  app.post(\"/upload-file/\", handleUploadFile);\n  app.post(\"/v1/upload-file/\", handleUploadFile);\n\n  // ─────────────────────────────────────────────\n  // GET /cloud/storage — Consommation actuelle de stockage\n  // ─────────────────────────────────────────────\n  const handleGetStorage = async (c: any) => {\n    try {\n      const token = extractToken(c.req.raw);\n      let userId = c.get(\"userId\");\n      let userPlan = c.get(\"userPlan\") || \"Free\";\n\n      if (token) {\n        try {\n          const payload = await verifyToken(token);\n          userId = (payload.sub as string) || userId;\n          userPlan = (payload.tier as string) || userPlan;\n        } catch {}\n      }\n\n      const sql = getDb();\n\n      // Résolution du user_id réel via mprojects_api_keys si clé API transmise\n      if (token) {\n        try {\n          const keyRows = await sql`\n            SELECT k.user_id, u.tier, u.email, u.username\n            FROM mprojects_api_keys k\n            LEFT JOIN users u ON k.user_id = u.id::text OR k.user_id = u.username OR k.user_id = u.email\n            WHERE k.api_key = ${token}::text\n            LIMIT 1\n          `;\n          if (keyRows.length > 0) {\n            userId = keyRows[0].user_id;\n            userPlan = keyRows[0].tier || userPlan;\n          }\n        } catch {}\n      }\n\n      if (!userId) {\n        return c.json({ error: \"Non authentifié.\" }, 401);\n      }\n\n      const [userRes, usageRes] = await Promise.all([\n        sql`SELECT tier FROM users WHERE id::text = ${userId}::text OR username = ${userId}::text OR email = ${userId}::text LIMIT 1`,\n        sql`\n          SELECT COALESCE(SUM(bytes_used::numeric), 0) as bytes_used, COALESCE(SUM(files_count::numeric), 0) as files_count \n          FROM cloud_storage_usage \n          WHERE (\n            user_id = ${userId}::text \n            OR user_id IN (SELECT id::text FROM users WHERE id::text = ${userId}::text OR email = ${userId}::text OR username = ${userId}::text)\n            OR user_id IN (SELECT email FROM users WHERE id::text = ${userId}::text OR email = ${userId}::text OR username = ${userId}::text)\n            OR user_id IN (SELECT username FROM users WHERE id::text = ${userId}::text OR email = ${userId}::text OR username = ${userId}::text)\n          ) LIMIT 1\n        `.catch(() => []),\n      ]);\n\n      const keyTier = extractTierFromApiKey(token);\n      const rawTier2 = keyTier || userRes[0]?.tier || userPlan || \"Free\";\n      const tier = String(rawTier2).trim();\n      const bytesUsed = Number(usageRes[0]?.bytes_used || 0);\n      const filesCount = Number(usageRes[0]?.files_count || 0);\n      const bytesLimit = getTierStorageLimitBytes(tier);\n      const percentUsed = bytesLimit > 0\n        ? Math.min(100, (bytesUsed / bytesLimit) * 100)\n        : 0;\n\n      return c.json({\n        bytes_limit: bytesLimit,\n        bytes_used: bytesUsed,\n        files_count: filesCount,\n        over_limit: bytesUsed >= bytesLimit,\n        percent_used: Math.round(percentUsed * 100) / 100,\n        tier,\n      });\n    } catch (err: any) {\n      console.error(\"Cloud Storage Error:\", err);\n      return c.json({ error: \"Erreur serveur.\" }, 500);\n    }\n  };\n\n  app.get(\"/cloud/storage\", handleGetStorage);\n  app.get(\"/v1/cloud/storage\", handleGetStorage);\n  app.get(\"/storage\", handleGetStorage);\n  app.get(\"/v1/storage\", handleGetStorage);\n\n  // ─────────────────────────────────────────────\n  // GET /cloud/files — Liste des fichiers de l'utilisateur\n  // ─────────────────────────────────────────────\n  const handleGetFiles = async (c: any) => {\n    try {\n      const token = extractToken(c.req.raw);\n      let userId = c.get(\"userId\");\n\n      if (token) {\n        try {\n          const payload = await verifyToken(token);\n          userId = (payload.sub as string) || userId;\n        } catch {}\n      }\n\n      const sql = getDb();\n\n      // Résolution du user_id réel via mprojects_api_keys si clé API transmise\n      if (token) {\n        try {\n          const keyRows = await sql`\n            SELECT k.user_id, u.tier, u.email, u.username\n            FROM mprojects_api_keys k\n            LEFT JOIN users u ON k.user_id = u.id::text OR k.user_id = u.username OR k.user_id = u.email\n            WHERE k.api_key = ${token}::text\n            LIMIT 1\n          `;\n          if (keyRows.length > 0) {\n            userId = keyRows[0].user_id;\n          }\n        } catch {}\n      }\n\n      if (!userId) {\n        return c.json({ error: \"Non authentifié.\" }, 401);\n      }\n\n      const files = await sql`\n        SELECT id, filename, original_name, url, size_bytes, mime_type, uploaded_at\n        FROM cloud_files\n        WHERE (\n          user_id = ${userId}::text \n          OR user_id IN (SELECT id::text FROM users WHERE id::text = ${userId}::text OR email = ${userId}::text OR username = ${userId}::text)\n          OR user_id IN (SELECT email FROM users WHERE id::text = ${userId}::text OR email = ${userId}::text OR username = ${userId}::text)\n          OR user_id IN (SELECT username FROM users WHERE id::text = ${userId}::text OR email = ${userId}::text OR username = ${userId}::text)\n        )\n        ORDER BY uploaded_at DESC\n        LIMIT 200\n      `.catch(() => []);\n\n      return c.json({ files, success: true });\n    } catch (err: any) {\n      console.error(\"Cloud Files Error:\", err);\n      return c.json({ error: \"Erreur serveur.\" }, 500);\n    }\n  };\n\n  app.get(\"/cloud/files\", handleGetFiles);\n  app.get(\"/v1/cloud/files\", handleGetFiles);\n  app.get(\"/files\", handleGetFiles);\n  app.get(\"/v1/files\", handleGetFiles);\n\n  // POST /cloud/upload & /v1/cloud/upload — Upload d'un fichier vers Z1 Storage avec fallback multi-buckets + mise à jour quota\n  const handleCloudUpload = async (c: any) => {\n    try {\n      const token = extractToken(c.req.raw);\n      if (!token) {\n        return c.json({ error: \"Non authentifié.\" }, 401);\n      }\n\n      const payload = await verifyToken(token);\n      const userId = payload.sub as string;\n      const sql = getDb();\n\n      // Lire le fichier\n      const body = await c.req.parseBody();\n      const file = body[\"file\"];\n      if (!(file instanceof File)) {\n        return c.json({ error: \"Fichier invalide ou non fourni.\" }, 400);\n      }\n\n      const fileSize = file.size;\n      if (fileSize === 0) {\n        return c.json({ error: \"Le fichier est vide.\" }, 400);\n      }\n      const MAX_FILE_SIZE = 10 * 1024 * 1024;\n      if (fileSize > MAX_FILE_SIZE) {\n        return c.json({ error: \"Fichier trop volumineux (max 10 MB).\" }, 413);\n      }\n      const ALLOWED_CLOUD_TYPES = [\n        \"image/jpeg\",\n        \"image/png\",\n        \"image/webp\",\n        \"image/gif\",\n        \"application/pdf\",\n        \"text/plain\",\n        \"text/markdown\",\n        \"text/csv\",\n        \"application/json\",\n      ];\n      const isCloudAllowed = !file.type ||\n        ALLOWED_CLOUD_TYPES.includes(file.type) ||\n        file.type.startsWith(\"image/\") ||\n        file.type.startsWith(\"text/\") ||\n        file.type === \"application/pdf\" ||\n        file.type === \"application/json\";\n      if (file.type && !isCloudAllowed) {\n        return c.json({ error: \"Type de fichier non autorisé.\" }, 400);\n      }\n\n      // Vérifier le quota AVANT d'uploader\n      const [userRes, usageRes] = await Promise.all([\n        sql`SELECT tier FROM users WHERE id::text = ${userId}::text LIMIT 1`,\n        sql`SELECT bytes_used FROM cloud_storage_usage WHERE user_id = ${userId}::text LIMIT 1`,\n      ]);\n\n      const rawTier = userRes[0]?.tier || \"Free\";\n      const tier = String(rawTier).trim();\n      const bytesUsed = Number(usageRes[0]?.bytes_used || 0);\n      const bytesLimit = getTierStorageLimitBytes(tier);\n\n      if (bytesUsed + fileSize > bytesLimit) {\n        return c.json(\n          {\n            bytes_limit: bytesLimit,\n            bytes_used: bytesUsed,\n            error: `Quota de stockage dépassé. Vous utilisez ${\n              formatQuotaBytes(bytesUsed)\n            } sur ${formatQuotaBytes(bytesLimit)} (tier ${tier}).`,\n            over_limit: true,\n          },\n          413,\n        );\n      }\n\n      // Générer une clé unique\n      const ext = file.name\n        .split(\".\")\n        .pop()\n        ?.replace(/[^a-zA-Z0-9]/g, \"\") || \"bin\";\n      const uniqueId = crypto.randomUUID();\n      const fileKey = `cloud/${userId}/${uniqueId}.${ext}`;\n      const cleanOriginal = file.name;\n      const cleanFilename = `${uniqueId}.${ext}`;\n\n      // Sélectionner un nœud de stockage dans le pool à 10 buckets\n      const primaryNode = selectStorageNode(`${userId}-${uniqueId}`);\n      const arrayBuffer = await file.arrayBuffer();\n\n      // Upload avec bascule automatique (fallback) sur les autres buckets du pool Z1 Storage\n      const uploadResult = await uploadWithFallback(\n        primaryNode,\n        fileKey,\n        arrayBuffer,\n        {\n          contentType: file.type || \"application/octet-stream\",\n          acl: \"public-read\",\n        },\n      );\n\n      if (!uploadResult.success) {\n        console.error(\n          \"Z1 Storage Upload Error (fallback épuisé):\",\n          uploadResult.error,\n        );\n        return c.json(\n          {\n            error:\n              \"Erreur lors de l'upload vers le stockage (tous les buckets en échec).\",\n          },\n          500,\n        );\n      }\n\n      const activeNode = uploadResult.activeNode;\n      const storedKey = `node-${activeNode.id}:${activeNode.bucket}:${fileKey}`;\n      const publicUrl = uploadResult.publicUrl;\n      const mimeType = file.type || \"application/octet-stream\";\n\n      // Insérer dans cloud_files\n      const inserted = await sql`\n        INSERT INTO cloud_files (user_id, filename, original_name, r2_key, url, size_bytes, mime_type)\n        VALUES (${userId}::text, ${cleanFilename}, ${cleanOriginal}, ${storedKey}, ${publicUrl}, ${fileSize}, ${mimeType})\n        RETURNING id, filename, original_name, url, size_bytes, mime_type, uploaded_at\n      `;\n\n      // Upsert cloud_storage_usage\n      await sql`\n        INSERT INTO cloud_storage_usage (user_id, bytes_used, files_count, updated_at)\n        VALUES (${userId}::text, ${fileSize}, 1, NOW())\n        ON CONFLICT (user_id)\n        DO UPDATE SET\n          bytes_used   = cloud_storage_usage.bytes_used + ${fileSize},\n          files_count  = cloud_storage_usage.files_count + 1,\n          updated_at   = NOW()\n      `;\n\n      const newBytesUsed = bytesUsed + fileSize;\n      const percentUsed = Math.round((newBytesUsed / bytesLimit) * 10_000) /\n        100;\n\n      return c.json({\n        file: inserted[0],\n        percent_used: percentUsed,\n        storage: {\n          bytes_limit: bytesLimit,\n          bytes_used: newBytesUsed,\n          over_limit: newBytesUsed >= bytesLimit,\n          percent_used: percentUsed,\n          tier,\n        },\n        success: true,\n      });\n    } catch (err: any) {\n      console.error(\"Cloud Upload Error:\", err);\n      return c.json({ error: \"Erreur serveur lors de l'upload Cloud.\" }, 500);\n    }\n  };\n\n  app.post(\"/cloud/upload\", handleCloudUpload);\n  app.post(\"/v1/cloud/upload\", handleCloudUpload);\n  app.post(\"/cloud/upload/\", handleCloudUpload);\n  app.post(\"/v1/cloud/upload/\", handleCloudUpload);\n\n  // DELETE /cloud/files/:id & /v1/cloud/files/:id — Suppression définitive d'un fichier\n  const handleDeleteFile = async (c: any) => {\n    try {\n      const token = extractToken(c.req.raw);\n      if (!token) {\n        return c.json({ error: \"Non authentifié.\" }, 401);\n      }\n\n      const payload = await verifyToken(token);\n      const userId = payload.sub as string;\n      const fileId = c.req.param(\"id\");\n      const sql = getDb();\n\n      // Récupérer le fichier (vérification propriété)\n      const fileRes = await sql`\n        SELECT id, r2_key, url, size_bytes\n        FROM cloud_files\n        WHERE id = ${fileId}::uuid AND user_id = ${userId}::text\n        LIMIT 1\n      `;\n\n      if (fileRes.length === 0) {\n        return c.json({ error: \"Fichier introuvable ou accès refusé.\" }, 404);\n      }\n\n      const { r2_key, url, size_bytes } = fileRes[0];\n\n      // Identifier le nœud et supprimer de Z1 Storage\n      const { node, rawKey } = findStorageNodeForRecord(r2_key, url);\n      const s3Client = await buildS3Client(node);\n      const deleteUrl = `${node.endpoint}/${node.bucket}/${rawKey}`;\n\n      try {\n        const delRes = await s3Client.fetch(deleteUrl, { method: \"DELETE\" });\n        if (!delRes.ok && (!r2_key || !r2_key.startsWith(\"node-\"))) {\n          // Si suppression échoue sur nœud par défaut pour un ancien fichier, tenter sur les autres nœuds du pool\n          for (const fallbackNode of getFallbackNodes(node).slice(1)) {\n            try {\n              const fbClient = await buildS3Client(fallbackNode);\n              const fbUrl =\n                `${fallbackNode.endpoint}/${fallbackNode.bucket}/${rawKey}`;\n              await fbClient.fetch(fbUrl, { method: \"DELETE\" });\n            } catch {}\n          }\n        }\n      } catch (s3Err) {\n        console.error(\"Z1 Delete Error (continuing anyway):\", s3Err);\n      }\n\n      // Supprimer de la base de données\n      await sql`DELETE FROM cloud_files WHERE id = ${fileId}::uuid AND user_id = ${userId}::text`;\n\n      // Décrémenter cloud_storage_usage\n      await sql`\n        UPDATE cloud_storage_usage\n        SET\n          bytes_used  = GREATEST(0, bytes_used - ${size_bytes}),\n          files_count = GREATEST(0, files_count - 1),\n          updated_at  = NOW()\n        WHERE user_id = ${userId}::text\n      `;\n\n      return c.json({ id: fileId, success: true });\n    } catch (err: any) {\n      console.error(\"Cloud Delete Error:\", err);\n      return c.json({ error: \"Erreur serveur lors de la suppression.\" }, 500);\n    }\n  };\n\n  app.delete(\"/cloud/files/:id\", handleDeleteFile);\n  app.delete(\"/v1/cloud/files/:id\", handleDeleteFile);\n}",[84],"851701e7-6e5a-4df7-b4b5-4329a5dec478","realtime.ts","8f14df76-a9c3-11f1-a1c2-1607ee4eb77e",315,["D",1789229709739],"/**\n * ============================================================================\n * VIBE SOCIAL PLATFORM — REALTIME (realtime.ts)\n * Server-Sent Events : notifications, messages, indicateur de frappe et stats\n * de posts poussés en direct (remplace le polling 15 s côté client).\n *\n * Architecture : une table d'événements transitoires `realtime_events`\n * (fiable même multi-isolates, contrairement à un bus mémoire) lue par la\n * boucle SSE ; les notifications et messages sont quant à eux détectés par\n * lecture directe de leurs tables (aucun site d'insertion à modifier).\n * ============================================================================\n */\n\nimport type { Hono } from \"npm:hono@4\";\nimport { streamSSE } from \"npm:hono/streaming\";\nimport { extractToken, getDb, verifyToken } from \"./config.ts\";\nimport { createRegisterMulti } from \"./vibe-common.ts\";\n\n// ─────────────────────────────────────────────\n// Table d'événements transitoires (typing, post_stats, dm_message)\n// ─────────────────────────────────────────────\nlet realtimeTablesReady = false;\n\nexport async function ensureRealtimeTables() {\n  if (realtimeTablesReady) return;\n  try {\n    const sql = getDb();\n    await sql`\n      CREATE TABLE IF NOT EXISTS realtime_events (\n        id BIGSERIAL PRIMARY KEY,\n        user_id INTEGER NOT NULL,\n        type TEXT NOT NULL,\n        payload JSONB,\n        created_at TIMESTAMPTZ DEFAULT NOW()\n      )\n    `;\n    await sql`CREATE INDEX IF NOT EXISTS idx_realtime_user ON realtime_events(user_id, id)`;\n    realtimeTablesReady = true;\n  } catch (err) {\n    console.warn(\n      \"[realtime] ensureRealtimeTables skipped:\",\n      (err as any)?.message,\n    );\n  }\n}\n\n/**\n * Pousse un événement temps réel vers un utilisateur (consommé par son flux SSE).\n * Jamais bloquant pour l'appelant : un échec de push ne doit pas faire échouer\n * l'action métier (like, message...).\n */\nexport async function pushRealtimeEvent(\n  userId: number | string | null | undefined,\n  type: string,\n  payload: any,\n) {\n  const target = Number(userId);\n  if (!target || isNaN(target)) return;\n  try {\n    await ensureRealtimeTables();\n    const sql = getDb();\n    await sql`\n      INSERT INTO realtime_events (user_id, type, payload)\n      VALUES (${target}, ${type}, ${JSON.stringify(payload || {})}::jsonb)\n    `;\n    // Purge opportuniste : les clients connectés lisent ces événements en <2 s\n    await sql`DELETE FROM realtime_events WHERE created_at < NOW() - INTERVAL '2 minutes'`\n      .catch(() => {});\n  } catch (err) {\n    console.warn(\"[realtime] pushRealtimeEvent failed:\", (err as any)?.message);\n  }\n}\n\n// ─────────────────────────────────────────────\n// Limiteur de connexions simultanées par utilisateur (best-effort par isolate)\n// ─────────────────────────────────────────────\nconst openConnections = new Map();\n\nconst MAX_CONNECTIONS_PER_USER = 2;\nconst TICK_MS = 1_000;\nconst HEARTBEAT_TICKS = 15;\nconst UNREAD_TICKS = 30;\nconst NOTIF_POLL_TICKS = 2;\n\nexport function registerRealtimeRoutes(app: Hono) {\n  const registerMulti = createRegisterMulti(app);\n  const handleStream = async (c: any) => {\n    // EventSource ne peut pas définir d'en-têtes : JWT accepté en ?token=\n    const token = extractToken(c.req.raw) || c.req.query(\"token\") || \"\";\n    if (!token) return c.json({ error: \"Non authentifié.\" }, 401);\n\n    let userId: number;\n    try {\n      const payload = await verifyToken(token);\n      userId = Number(payload.sub || (payload as any).id);\n      if (!userId || isNaN(userId)) throw new Error(\"no user\");\n    } catch {\n      return c.json({ error: \"Token invalide.\" }, 401);\n    }\n\n    await ensureRealtimeTables();\n\n    const key = String(userId);\n    const current = openConnections.get(key) || 0;\n    if (current >= MAX_CONNECTIONS_PER_USER) {\n      return c.json(\n        { error: \"Trop de connexions temps réel pour ce compte.\" },\n        429,\n      );\n    }\n    openConnections.set(key, current + 1);\n\n    const sql = getDb();\n\n    // Chevauchement initial de 3 s : rattrape ce qui a été émis juste avant la\n    // connexion (le client déduplique par id côté UI).\n    const seenNotificationIds = new Set();\n    const seenMessageIds = new Set();\n    let notifCursor = new Date(Date.now() - 3_000).toISOString();\n    let dmCursor = new Date(Date.now() - 3_000).toISOString();\n    let lastEventId = 0;\n    let tick = 0;\n\n    try {\n      return streamSSE(c, async (sse: any) => {\n        let aborted = false;\n        sse.onAbort(() => {\n          aborted = true;\n        });\n\n        const pushUnreadCounts = async () => {\n          try {\n            const counts = await sql`\n              SELECT\n                (SELECT COUNT(*) FROM notifications WHERE recipient_id = ${userId} AND is_read = FALSE) AS unread_notifications,\n                (\n                  (SELECT COUNT(*) FROM direct_messages WHERE recipient_id = ${userId} AND is_read = FALSE) +\n                  (SELECT COUNT(*) FROM direct_messages m\n                    JOIN dm_group_members gm ON gm.conversation_id = m.conversation_id AND gm.user_id = ${userId}\n                    WHERE m.sender_id <> ${userId}\n                      AND NOT COALESCE((m.read_by ? ${userId}::text), FALSE))\n                ) AS unread_messages\n            `;\n            await sse.writeSSE({\n              event: \"unread_counts\",\n              data: JSON.stringify({\n                unread_notifications: Number(\n                  counts[0]?.unread_notifications || 0,\n                ),\n                unread_messages: Number(counts[0]?.unread_messages || 0),\n              }),\n            });\n          } catch {}\n        };\n\n        try {\n          await sse.writeSSE({\n            event: \"connected\",\n            data: JSON.stringify({\n              user_id: userId,\n              at: new Date().toISOString(),\n            }),\n          });\n          await pushUnreadCounts();\n        } catch {\n          aborted = true;\n        }\n\n        while (!aborted) {\n          await sse.sleep(TICK_MS);\n          if (aborted) break;\n          tick += 1;\n\n          try {\n            // 1. Événements transitoires poussés (dm_message, dm_typing, post_stats)\n            const events = await sql`\n              SELECT id, type, payload FROM realtime_events\n              WHERE user_id = ${userId} AND id > ${lastEventId}\n              ORDER BY id ASC LIMIT 50\n            `;\n            for (const ev of events) {\n              lastEventId = Number(ev.id);\n              await sse.writeSSE({\n                event: ev.type,\n                data: JSON.stringify(ev.payload ?? {}),\n              });\n            }\n          } catch (pollErr) {\n            console.warn(\n              \"[realtime] events poll error:\",\n              (pollErr as any)?.message,\n            );\n          }\n\n          // 2. Nouvelles notifications (toutes types : like, repost, mention, follow, dm...)\n          if (tick % NOTIF_POLL_TICKS === 0) {\n            try {\n              const notifs = await sql`\n                SELECT n.id, n.type, n.post_id, n.comment_id, n.message, n.is_read, n.created_at,\n                       a.username AS actor_username, p.display_name AS actor_display_name, p.avatar_url AS actor_avatar_url\n                FROM notifications n\n                LEFT JOIN users a ON a.id = n.actor_id\n                LEFT JOIN profiles p ON p.user_id = n.actor_id\n                WHERE n.recipient_id = ${userId} AND n.created_at > ${notifCursor}\n                ORDER BY n.created_at ASC LIMIT 20\n              `;\n              let maxNotifAt: string | null = null;\n              for (const n of notifs) {\n                if (seenNotificationIds.has(String(n.id))) continue;\n                seenNotificationIds.add(String(n.id));\n                if (!maxNotifAt || String(n.created_at) > maxNotifAt) {\n                  maxNotifAt = String(n.created_at);\n                }\n                await sse.writeSSE({\n                  event: \"notification\",\n                  data: JSON.stringify(n),\n                });\n              }\n              if (maxNotifAt) notifCursor = maxNotifAt;\n            } catch (notifErr) {\n              console.warn(\n                \"[realtime] notifications poll error:\",\n                (notifErr as any)?.message,\n              );\n            }\n          }\n\n          // 3. Rattrapage périodique des badges (filet si un événement a été manqué)\n          if (tick % UNREAD_TICKS === 0) {\n            await pushUnreadCounts();\n          }\n\n          // 4. Heartbeat (keep-alive proxies)\n          if (tick % HEARTBEAT_TICKS === 0) {\n            try {\n              await sse.writeSSE({ event: \"ping\", data: String(Date.now()) });\n            } catch {\n              break;\n            }\n          }\n        }\n      });\n    } finally {\n      openConnections.set(\n        key,\n        Math.max(0, (openConnections.get(key) || 1) - 1),\n      );\n    }\n  };\n\n  registerMulti(\"get\", [\n    \"/api/vibe/realtime/stream\",\n    \"/vibe/realtime/stream\",\n    \"/v1/realtime/stream\",\n    \"/realtime/stream\",\n  ], handleStream);\n\n  // Indicateur de frappe : le client l'émet (throttlé) pendant la saisie d'un DM\n  const handleTyping = async (c: any) => {\n    try {\n      const token = extractToken(c.req.raw);\n      if (!token) return c.json({ error: \"Non authentifié.\" }, 401);\n      const payload = await verifyToken(token);\n      const userId = Number(payload.sub || (payload as any).id);\n\n      const body = await c.req.json().catch(() => ({} as any));\n      const partnerId = Number(body?.partner_id);\n      const typing = body?.typing !== false;\n      if (!partnerId || isNaN(partnerId) || partnerId === userId) {\n        return c.json({ error: \"Partenaire requis.\" }, 400);\n      }\n\n      const sql = getDb();\n      let actor: any = {};\n      try {\n        const rows = await sql`\n          SELECT u.username, p.display_name\n          FROM users u LEFT JOIN profiles p ON p.user_id = u.id\n          WHERE u.id = ${userId} LIMIT 1\n        `;\n        actor = rows[0] || {};\n      } catch {}\n\n      await pushRealtimeEvent(partnerId, \"dm_typing\", {\n        user_id: userId,\n        username: actor.username || null,\n        display_name: actor.display_name || null,\n        typing,\n      });\n\n      return c.json({ success: true });\n    } catch (err: any) {\n      return c.json(\n        { error: err?.message || \"Erreur indicateur de frappe.\" },\n        500,\n      );\n    }\n  };\n\n  registerMulti(\"post\", [\n    \"/api/vibe/dms/typing\",\n    \"/vibe/dms/typing\",\n    \"/v1/dms/typing\",\n  ], handleTyping);\n}",[632],"b6b377a3-0af6-4e6e-b054-db9c89db6eed",211,["D",1788618643754],"import type { Hono } from \"npm:hono@4\";\nimport { getDb } from \"./config.ts\";\n\nexport const STATIC_PROJECTS_LIST = [\n  {\n    category: \"Web Application\",\n    created_at: \"2026-08-01T00:00:00.000Z\",\n    description:\n      \"Application d'IA en ligne web directement et simplement pour discuter avec l'IA mAI.\",\n    features: [\"Chat Web\", \"Interface fluide\", \"Streaming en direct\"],\n    id: \"proj_web\",\n    is_public: true,\n    label: \"Release Candidate\",\n    name: \"Web\",\n    project_id: \"web\",\n    repository: \"https://github.com/mDevsLabs/Web\",\n    status: \"rc\",\n    version: \"0.1.0\",\n  },\n  {\n    category: \"Social Network\",\n    created_at: \"2026-09-01T00:00:00.000Z\",\n    description:\n      \"Réseau social open source où l'IA mAI est intégrée nativement : feed social, conversations et création de contenu assistée.\",\n    features: [\n      \"Feed social\",\n      \"IA mAI intégrée\",\n      \"Création assistée\",\n      \"Open Source\",\n    ],\n    id: \"proj_vibe\",\n    is_public: true,\n    label: \"Bêta\",\n    name: \"Vibe\",\n    project_id: \"vibe\",\n    repository: \"https://github.com/mDevsLabs/Vibe\",\n    status: \"beta\",\n    version: \"0.1.0\",\n  },\n  {\n    category: \"Extensions\",\n    created_at: \"2026-08-05T00:00:00.000Z\",\n    description:\n      \"Ensemble d'extensions pour diverses applications pour discuter avec mAI directement (navigateur, VS Code...).\",\n    features: [\"Extension navigateur\", \"Extension VS Code\", \"Accès contextuel\"],\n    id: \"proj_pulse\",\n    is_public: true,\n    label: \"Release Candidate\",\n    name: \"Pulse\",\n    project_id: \"pulse\",\n    repository: \"https://github.com/mDevsLabs/Pulse\",\n    status: \"rc\",\n    version: \"0.2.0\",\n  },\n  {\n    category: \"Developer Tools\",\n    created_at: \"2026-08-10T00:00:00.000Z\",\n    description:\n      \"Discussions et séances de codage dans le terminal CLI via mAI.\",\n    features: [\n      \"Terminal interactif\",\n      \"Génération de code\",\n      \"Workflows développeur\",\n    ],\n    id: \"proj_cli\",\n    is_public: true,\n    label: \"Release Candidate\",\n    name: \"CLI\",\n    project_id: \"cli\",\n    repository: \"https://github.com/mDevsLabs/CLI\",\n    status: \"rc\",\n    version: \"0.5.0\",\n  },\n  {\n    category: \"Developer Tools\",\n    created_at: \"2026-08-20T00:00:00.000Z\",\n    description:\n      \"IDE IA de nouvelle génération avec agents IA autonomes, orchestration multi-modèles et support natif des outils MCP.\",\n    features: [\n      \"IDE IA Intelligent\",\n      \"Agents Autonomes\",\n      \"Outils MCP\",\n      \"Multi-Modèles\",\n    ],\n    id: \"proj_coder\",\n    is_public: true,\n    label: \"Release Candidate\",\n    name: \"Coder\",\n    project_id: \"coder\",\n    repository: \"https://github.com/mDevsLabs/Coder\",\n    status: \"rc\",\n    version: \"0.1.0\",\n  },\n  {\n    category: \"Cloud & Storage\",\n    created_at: \"2026-08-15T00:00:00.000Z\",\n    description:\n      \"Stockage cloud de documents et intégration d'mAI pour des résumés.\",\n    features: [\n      \"Stockage sécurisé\",\n      \"Résumés automatiques\",\n      \"Indexation de documents\",\n    ],\n    id: \"proj_cloud\",\n    is_public: true,\n    label: \"Réflexion\",\n    name: \"Cloud\",\n    project_id: \"cloud\",\n    repository: \"\",\n    status: \"conception\",\n    version: \"0.0.1\",\n  },\n  {\n    category: \"Site & Web\",\n    created_at: \"2026-08-01T00:00:00.000Z\",\n    description: \"Site officiel et application web mAI.\",\n    features: [\"Site\", \"Web App\"],\n    id: \"proj_site\",\n    is_public: true,\n    label: \"Alpha\",\n    name: \"Site\",\n    project_id: \"site\",\n    repository: \"https://github.com/mDevsLabs/Site\",\n    status: \"alpha\",\n    version: \"0.1.0\",\n  },\n  {\n    category: \"Extensions\",\n    created_at: \"2026-08-05T00:00:00.000Z\",\n    description: \"Extension Pulse pour le navigateur web.\",\n    features: [\"Extension navigateur\", \"Chat mAI\"],\n    id: \"proj_pulse_web\",\n    is_public: true,\n    label: \"Bêta\",\n    name: \"Pulse - Web\",\n    project_id: \"pulse-web\",\n    repository: \"https://github.com/mDevsLabs/Pulse-Web\",\n    status: \"beta\",\n    version: \"0.2.0\",\n  },\n  {\n    category: \"Extensions\",\n    created_at: \"2026-08-05T00:00:00.000Z\",\n    description: \"Extension Pulse pour l'IDE JetBrains.\",\n    features: [\"Extension JetBrains\", \"Contextuel\"],\n    id: \"proj_pulse_jetbrains\",\n    is_public: true,\n    label: \"Bêta\",\n    name: \"Pulse - JetBrains\",\n    project_id: \"pulse-jetbrains\",\n    repository: \"https://github.com/mDevsLabs/Pulse-JetBrains\",\n    status: \"beta\",\n    version: \"0.2.0\",\n  },\n  {\n    category: \"Extensions\",\n    created_at: \"2026-08-05T00:00:00.000Z\",\n    description: \"Extension Pulse pour VS Code.\",\n    features: [\"Extension VS Code\", \"Chat mAI\"],\n    id: \"proj_pulse_vscode\",\n    is_public: true,\n    label: \"Bêta\",\n    name: \"Pulse - VS Code\",\n    project_id: \"pulse-vscode\",\n    repository: \"https://github.com/mDevsLabs/Pulse-VSCode\",\n    status: \"beta\",\n    version: \"0.2.0\",\n  },\n  {\n    category: \"Desktop\",\n    created_at: \"2026-08-15T00:00:00.000Z\",\n    description: \"Application desktop intégrée mAI.\",\n    features: [\"Desktop\", \"Notifications\", \"Local\"],\n    id: \"proj_desktop\",\n    is_public: true,\n    label: \"Concept\",\n    name: \"Desktop\",\n    project_id: \"desktop\",\n    repository: \"https://github.com/mDevsLabs/Desktop\",\n    status: \"conception\",\n    version: \"0.0.1\",\n  },\n  {\n    category: \"Skills\",\n    created_at: \"2026-08-10T00:00:00.000Z\",\n    description: \"Compétences et agents spécialisés mAI.\",\n    features: [\"Agents\", \"Workflows\"],\n    id: \"proj_skills\",\n    is_public: true,\n    label: \"Concept\",\n    name: \"Skills\",\n    project_id: \"skills\",\n    repository: \"https://github.com/mDevsLabs/Skills\",\n    status: \"conception\",\n    version: \"0.0.1\",\n  },\n  {\n    category: \"Plugins\",\n    created_at: \"2026-08-10T00:00:00.000Z\",\n    description: \"Écosystème de plugins mAI.\",\n    features: [\"Plugins\", \"Intégrations\"],\n    id: \"proj_plugins\",\n    is_public: true,\n    label: \"Concept\",\n    name: \"Plugins\",\n    project_id: \"plugins\",\n    repository: \"https://github.com/mDevsLabs/Plugins\",\n    status: \"conception\",\n    version: \"0.0.1\",\n  },\n  {\n    category: \"API\",\n    created_at: \"2026-03-01T00:00:00.000Z\",\n    description: \"Hub API mAI et agrégation de modèles.\",\n    features: [\"API Gateway\", \"Modèles LLM\"],\n    id: \"proj_api\",\n    is_public: true,\n    label: \"Bêta\",\n    name: \"API\",\n    project_id: \"api\",\n    repository: \"https://github.com/mDevsLabs/API\",\n    status: \"beta\",\n    version: \"0.5.0\",\n  },\n  {\n    category: \"Autre\",\n    created_at: \"2026-08-01T00:00:00.000Z\",\n    description: \"Autres projets et expérimentations mAI.\",\n    features: [\"Expérimentations\"],\n    id: \"proj_autre\",\n    is_public: true,\n    label: \"Concept\",\n    name: \"Autre\",\n    project_id: \"autre\",\n    repository: \"\",\n    status: \"conception\",\n    version: \"0.0.1\",\n  },\n  {\n    category: \"Search Engine\",\n    created_at: \"2026-02-01T00:00:00.000Z\",\n    description:\n      \"Moteur de recherche sémantique et d'indexation vectorielle ultra-rapide.\",\n    features: [\"Indexation hybride\", \"Recherche locale\"],\n    id: \"proj_msearch\",\n    is_public: true,\n    label: \"Archivé\",\n    name: \"mSearch\",\n    project_id: \"msearch\",\n    repository: \"https://github.com/mDevsLabs/mSearch\",\n    status: \"archived\",\n    version: \"1.0.3\",\n  },\n  {\n    category: \"API Gateway\",\n    created_at: \"2026-03-01T00:00:00.000Z\",\n    description:\n      \"Hub universel d'agrégation et de routage intelligent d'API et modèles LLM.\",\n    features: [\"Load balancing\", \"Multi-fournisseurs\"],\n    id: \"proj_openprovider\",\n    is_public: true,\n    label: \"Archivé\",\n    name: \"OpenProvider\",\n    project_id: \"openprovider\",\n    repository: \"https://github.com/mDevsLabs/OpenProvider\",\n    status: \"archived\",\n    version: \"0.5.0\",\n  },\n  {\n    category: \"Games\",\n    created_at: \"2026-03-15T00:00:00.000Z\",\n    description: \"Jeu vidéo du style Block Blast\",\n    features: [\"Video game\", \"Assembler\"],\n    id: \"proj_snob\",\n    is_public: true,\n    label: \"Archivé\",\n    name: \"Snob\",\n    project_id: \"snob\",\n    repository: \"https://github.com/mDevsLabs/Snob\",\n    status: \"archived\",\n    version: \"1.0.1\",\n  },\n  {\n    category: \"AI Suite\",\n    created_at: \"2026-01-15T00:00:00.000Z\",\n    description: \"Ancienne interface web de mAI.\",\n    features: [\"Chat Completions\", \"Embeddings\"],\n    id: \"proj_mai_legacy\",\n    is_public: true,\n    label: \"Archivé\",\n    name: \"mAI Web (Legacy)\",\n    project_id: \"mai\",\n    repository: \"https://github.com/mDevsLabs/mAI\",\n    status: \"archived\",\n    version: \"2.4.0\",\n  },\n];\n\nexport const STATIC_PROJECTS_MAP: Record = {\n  cli: {\n    category: \"Developer Tools\",\n    created_at: \"2026-08-10T00:00:00.000Z\",\n    description:\n      \"Discussions et séances de codage dans le terminal CLI via mAI.\",\n    is_public: true,\n    label: \"Bêta\",\n    name: \"CLI\",\n    project_id: \"cli\",\n    repository: \"https://github.com/mDevsLabs/CLI\",\n    status: \"beta\",\n  },\n  cloud: {\n    category: \"Cloud & Storage\",\n    created_at: \"2026-08-15T00:00:00.000Z\",\n    description:\n      \"Stockage cloud de documents et intégration d'mAI pour des résumés.\",\n    is_public: true,\n    label: \"Réflexion\",\n    name: \"Cloud\",\n    project_id: \"cloud\",\n    repository: \"\",\n    status: \"conception\",\n  },\n  coder: {\n    category: \"Developer Tools\",\n    created_at: \"2026-08-20T00:00:00.000Z\",\n    description:\n      \"IDE IA de nouvelle génération avec agents IA autonomes, orchestration multi-modèles et support natif des outils MCP.\",\n    is_public: true,\n    label: \"Alpha\",\n    name: \"Coder\",\n    project_id: \"coder\",\n    repository: \"https://github.com/mDevsLabs/Coder\",\n    status: \"alpha\",\n  },\n  mai: {\n    category: \"AI Suite\",\n    created_at: \"2026-01-15T00:00:00.000Z\",\n    description: \"Ancienne interface web de mAI.\",\n    is_public: true,\n    label: \"Archivé\",\n    name: \"mAI Web (Legacy)\",\n    project_id: \"mai\",\n    repository: \"https://github.com/mDevsLabs/mAI\",\n    status: \"archived\",\n  },\n  maicli: {\n    category: \"CLI Tool\",\n    created_at: \"2026-02-10T00:00:00.000Z\",\n    description:\n      \"Interface en ligne de commande professionnelle pour l'écosystème mAI.\",\n    is_public: true,\n    label: \"Archivé\",\n    name: \"mAI CLI (Legacy)\",\n    project_id: \"maicli\",\n    repository: \"https://github.com/mDevsLabs/mAI-CLI\",\n    status: \"archived\",\n  },\n  msearch: {\n    category: \"Search Engine\",\n    created_at: \"2026-02-01T00:00:00.000Z\",\n    description: \"Moteur de recherche sémantique et d'indexation vectorielle.\",\n    is_public: true,\n    label: \"Archivé\",\n    name: \"mSearch\",\n    project_id: \"msearch\",\n    repository: \"https://github.com/mDevsLabs/mSearch\",\n    status: \"archived\",\n  },\n  site: {\n    category: \"Site & Web\",\n    created_at: \"2026-08-01T00:00:00.000Z\",\n    description: \"Site officiel et application web mAI.\",\n    is_public: true,\n    label: \"Alpha\",\n    name: \"Site\",\n    project_id: \"site\",\n    repository: \"https://github.com/mDevsLabs/Site\",\n    status: \"alpha\",\n  },\n  \"pulse-web\": {\n    category: \"Extensions\",\n    created_at: \"2026-08-05T00:00:00.000Z\",\n    description: \"Extension Pulse pour le navigateur web.\",\n    is_public: true,\n    label: \"Bêta\",\n    name: \"Pulse - Web\",\n    project_id: \"pulse-web\",\n    repository: \"https://github.com/mDevsLabs/Pulse-Web\",\n    status: \"beta\",\n  },\n  \"pulse-jetbrains\": {\n    category: \"Extensions\",\n    created_at: \"2026-08-05T00:00:00.000Z\",\n    description: \"Extension Pulse pour l'IDE JetBrains.\",\n    is_public: true,\n    label: \"Bêta\",\n    name: \"Pulse - JetBrains\",\n    project_id: \"pulse-jetbrains\",\n    repository: \"https://github.com/mDevsLabs/Pulse-JetBrains\",\n    status: \"beta\",\n  },\n  \"pulse-vscode\": {\n    category: \"Extensions\",\n    created_at: \"2026-08-05T00:00:00.000Z\",\n    description: \"Extension Pulse pour VS Code.\",\n    is_public: true,\n    label: \"Bêta\",\n    name: \"Pulse - VS Code\",\n    project_id: \"pulse-vscode\",\n    repository: \"https://github.com/mDevsLabs/Pulse-VSCode\",\n    status: \"beta\",\n  },\n  desktop: {\n    category: \"Desktop\",\n    created_at: \"2026-08-15T00:00:00.000Z\",\n    description: \"Application desktop intégrée mAI.\",\n    is_public: true,\n    label: \"Concept\",\n    name: \"Desktop\",\n    project_id: \"desktop\",\n    repository: \"https://github.com/mDevsLabs/Desktop\",\n    status: \"conception\",\n  },\n  skills: {\n    category: \"Skills\",\n    created_at: \"2026-08-10T00:00:00.000Z\",\n    description: \"Compétences et agents spécialisés mAI.\",\n    is_public: true,\n    label: \"Concept\",\n    name: \"Skills\",\n    project_id: \"skills\",\n    repository: \"https://github.com/mDevsLabs/Skills\",\n    status: \"conception\",\n  },\n  plugins: {\n    category: \"Plugins\",\n    created_at: \"2026-08-10T00:00:00.000Z\",\n    description: \"Écosystème de plugins mAI.\",\n    is_public: true,\n    label: \"Concept\",\n    name: \"Plugins\",\n    project_id: \"plugins\",\n    repository: \"https://github.com/mDevsLabs/Plugins\",\n    status: \"conception\",\n  },\n  api: {\n    category: \"API\",\n    created_at: \"2026-03-01T00:00:00.000Z\",\n    description: \"Hub API mAI et agrégation de modèles.\",\n    is_public: true,\n    label: \"Bêta\",\n    name: \"API\",\n    project_id: \"api\",\n    repository: \"https://github.com/mDevsLabs/API\",\n    status: \"beta\",\n  },\n  autre: {\n    category: \"Autre\",\n    created_at: \"2026-08-01T00:00:00.000Z\",\n    description: \"Autres projets et expérimentations mAI.\",\n    is_public: true,\n    label: \"Concept\",\n    name: \"Autre\",\n    project_id: \"autre\",\n    repository: \"\",\n    status: \"conception\",\n  },\n  openprovider: {\n    category: \"API Gateway\",\n    created_at: \"2026-03-01T00:00:00.000Z\",\n    description:\n      \"Hub universel d'agrégation et de routage d'API et modèles LLM.\",\n    is_public: true,\n    label: \"Archivé\",\n    name: \"OpenProvider\",\n    project_id: \"openprovider\",\n    repository: \"https://github.com/mDevsLabs/OpenProvider\",\n    status: \"archived\",\n  },\n  pulse: {\n    category: \"Extensions\",\n    created_at: \"2026-08-05T00:00:00.000Z\",\n    description:\n      \"Ensemble d'extensions pour diverses applications pour discuter avec mAI directement (navigateur, VS Code...).\",\n    is_public: true,\n    label: \"Bêta\",\n    name: \"Pulse\",\n    project_id: \"pulse\",\n    repository: \"https://github.com/mDevsLabs/Pulse\",\n    status: \"beta\",\n  },\n  snob: {\n    category: \"Games\",\n    created_at: \"2026-03-15T00:00:00.000Z\",\n    description: \"Jeu vidéo du style Block Blast.\",\n    is_public: true,\n    label: \"Archivé\",\n    name: \"Snob\",\n    project_id: \"snob\",\n    repository: \"https://github.com/mDevsLabs/Snob\",\n    status: \"archived\",\n  },\n  web: {\n    category: \"Web Application\",\n    created_at: \"2026-08-01T00:00:00.000Z\",\n    description:\n      \"Application d'IA en ligne web directement et simplement pour discuter avec l'IA mAI.\",\n    is_public: true,\n    label: \"Alpha\",\n    name: \"Web\",\n    project_id: \"web\",\n    repository: \"https://github.com/mDevsLabs/Web\",\n    status: \"alpha\",\n  },\n};\n\nexport function registerProjectRoutes(app: Hono) {\n  // GET /v1/projects\n  app.get(\"/v1/projects\", async (c) => {\n    try {\n      const sql = getDb();\n      const userId = c.get(\"userId\");\n      const dbProjects =\n        await sql`SELECT * FROM mprojects_projects WHERE user_id = ${userId} ORDER BY created_at DESC LIMIT 50`;\n      return c.json({\n        data: [...STATIC_PROJECTS_LIST, ...dbProjects],\n        object: \"list\",\n      });\n    } catch (_err) {\n      return c.json({ data: STATIC_PROJECTS_LIST, object: \"list\" });\n    }\n  });\n\n  // POST /v1/projects\n  app.post(\"/v1/projects\", async (c) => {\n    const sql = getDb();\n    const userId = c.get(\"userId\");\n    const body = await c.req.json();\n    if (!body.name) {\n      return c.json({ error: \"Le nom du projet est obligatoire.\" }, 400);\n    }\n\n    const projectId = \"proj-\" + Math.random().toString(36).substr(2, 9);\n\n    await sql`\n      INSERT INTO mprojects_projects (user_id, project_id, name, description, is_public)\n      VALUES (${userId}, ${projectId}, ${body.name}, ${\n      body.description || \"\"\n    }, ${body.isPublic || false})\n    `;\n\n    return c.json({ name: body.name, project_id: projectId, success: true });\n  });\n\n  // GET /v1/projects/:id\n  app.get(\"/v1/projects/:id\", async (c) => {\n    const projectId = c.req.param(\"id\").toLowerCase();\n\n    if (STATIC_PROJECTS_MAP[projectId]) {\n      return c.json({ project: STATIC_PROJECTS_MAP[projectId] });\n    }\n\n    const sql = getDb();\n    const userId = c.get(\"userId\");\n    const projects = await sql`\n      SELECT * FROM mprojects_projects \n      WHERE (user_id = ${userId} OR is_public = TRUE) AND LOWER(project_id) = ${projectId} \n      LIMIT 1\n    `;\n\n    if (projects.length === 0) {\n      return c.json({ error: \"Project not found\" }, 404);\n    }\n\n    return c.json({ project: projects[0] });\n  });\n\n  // PUT /v1/projects/:id\n  app.put(\"/v1/projects/:id\", async (c) => {\n    const sql = getDb();\n    const userId = c.get(\"userId\");\n    const projectId = c.req.param(\"id\");\n    const body = await c.req.json();\n\n    const existing =\n      await sql`SELECT id FROM mprojects_projects WHERE user_id = ${userId} AND project_id = ${projectId} LIMIT 1`;\n    if (existing.length === 0) {\n      return c.json({ error: \"Projet non trouvé ou non autorisé.\" }, 404);\n    }\n\n    const name = body.name;\n    const description = body.description;\n    const isPublic = body.isPublic;\n\n    await sql`\n      UPDATE mprojects_projects\n      SET name = COALESCE(${name}, name),\n          description = COALESCE(${description}, description),\n          is_public = COALESCE(${isPublic}, is_public),\n          updated_at = NOW()\n      WHERE user_id = ${userId} AND project_id = ${projectId}\n    `;\n\n    return c.json({\n      message: \"Projet mis à jour.\",\n      project_id: projectId,\n      success: true,\n    });\n  });\n\n  // DELETE /v1/projects/:id\n  app.delete(\"/v1/projects/:id\", async (c) => {\n    const sql = getDb();\n    const userId = c.get(\"userId\");\n    const projectId = c.req.param(\"id\");\n\n    const result = await sql`\n      DELETE FROM mprojects_projects \n      WHERE user_id = ${userId} AND project_id = ${projectId}\n      RETURNING id\n    `;\n\n    if (result.length === 0) {\n      return c.json({ error: \"Projet non trouvé ou déjà supprimé.\" }, 404);\n    }\n\n    return c.json({ message: \"Projet supprimé avec succès.\", success: true });\n  });\n\n  // GET /v1/projects/:id/stats\n  app.get(\"/v1/projects/:id/stats\", async (c) => {\n    const sql = getDb();\n    const userId = c.get(\"userId\");\n    const projectId = c.req.param(\"id\");\n\n    const projects =\n      await sql`SELECT id, name, created_at FROM mprojects_projects WHERE user_id = ${userId} AND project_id = ${projectId} LIMIT 1`;\n    if (projects.length === 0) {\n      return c.json({ error: \"Projet non trouvé.\" }, 404);\n    }\n\n    return c.json({\n      active_deployments: 1,\n      name: projects[0].name,\n      project_id: projectId,\n      requests_count: Math.floor(Math.random() * 500) + 12,\n      status: \"healthy\",\n      uptime_percentage: 99.98,\n    });\n  });\n}",[102],"78777eed-b81f-4cdd-828b-27a70d2a6a4f",217,["D",1788620602782],27,"import type { Hono } from \"npm:hono@4\";\nimport {\n  extractToken,\n  getDb,\n  getTierMaiTokenLimit,\n  getTierSpeechLimit,\n  getUserQuotaBoost,\n  getWeekData,\n  isPaidTier,\n  verifyToken,\n} from \"./config.ts\";\nimport { maiModelsList } from \"./maiModels.ts\";\n\nfunction getOpenRouterApiKey(userCustomKey?: string | null): string {\n  if (userCustomKey && userCustomKey.trim().startsWith(\"sk-or-\")) {\n    return userCustomKey.trim();\n  }\n  return Deno.env.get(\"OPENROUTER_API_KEY\") || \"\";\n}\n\nexport function registerModelRoutes(app: Hono) {\n  // ─────────────────────────────────────────────\n  // GET /v1/usage & /usage\n  // ─────────────────────────────────────────────\n  const handleGetUsage = async (c: any) => {\n    try {\n      const token = extractToken(c.req.raw) || (c as any).get?.(\"apiKey\");\n      let userId = (c as any).get?.(\"userId\");\n\n      if (token) {\n        try {\n          const payload = await verifyToken(token);\n          userId = (payload.sub as string) || userId;\n        } catch {}\n      }\n\n      const sql = getDb();\n\n      // Résolution de l'identifiant via mprojects_api_keys si clé API fournie\n      if (token) {\n        try {\n          const keyRows = await sql`\n            SELECT k.user_id, u.tier, u.email, u.username\n            FROM mprojects_api_keys k\n            LEFT JOIN users u ON k.user_id = u.id::text OR k.user_id = u.username OR k.user_id = u.email\n            WHERE k.api_key = ${token}::text\n            LIMIT 1\n          `;\n          if (keyRows.length > 0) {\n            userId = keyRows[0].user_id;\n          }\n        } catch {}\n      }\n\n      if (!userId) {\n        return c.json({ error: \"Non authentifié.\" }, 401);\n      }\n\n      const { weekStartStr, nextResetIso } = getWeekData();\n\n      const userResult =\n        await sql`SELECT id, tier, email, username, phone, avatar_url FROM users WHERE id::text = ${userId}::text OR username = ${userId}::text OR email = ${userId}::text LIMIT 1`;\n      const user = userResult[0];\n      const resolvedUserId = user ? user.id : userId;\n\n      const [usageResult, speechResult] = await Promise.all([\n        sql`\n          SELECT COALESCE(SUM(tokens_used::numeric), 0) as tokens_used \n          FROM weekly_usage \n          WHERE user_id = ${resolvedUserId}::integer AND week_start = ${weekStartStr}::date\n        `.catch((e) => {\n          console.error(\"[usageResult] Error:\", e);\n          return [];\n        }),\n        sql`\n          SELECT COALESCE(SUM(tokens_used::numeric), 0) as tokens_used \n          FROM weekly_speech_usage \n          WHERE user_id = ${resolvedUserId}::text AND week_start = ${weekStartStr}::date\n        `.catch((e) => {\n          console.error(\"[speechResult] Error:\", e);\n          return [];\n        }),\n      ]);\n      const tokensUsed = usageResult[0]?.tokens_used || 0;\n      const speechTokensUsed = Number(speechResult?.[0]?.tokens_used || 0);\n      const userTier = user?.tier || \"Free\";\n      const maiBoost = await getUserQuotaBoost(sql, resolvedUserId, \"mai\");\n      const audioBoost = await getUserQuotaBoost(sql, resolvedUserId, \"audio\");\n      const limit = getTierMaiTokenLimit(userTier) + maiBoost;\n      const speechLimit = getTierSpeechLimit(userTier) + audioBoost;\n\n      return c.json({\n        avatarUrl: user?.avatar_url,\n        email: user?.email,\n        id: userId,\n        limit,\n        phone: user?.phone,\n        resetAt: nextResetIso,\n        speechLimit,\n        speechTokensUsed,\n        tier: userTier,\n        tokensUsed,\n        username: user?.username,\n        weekStart: weekStartStr,\n      });\n    } catch {\n      return c.json({ error: \"Erreur serveur.\" }, 500);\n    }\n  };\n\n  app.get(\"/usage\", handleGetUsage);\n  app.get(\"/v1/usage\", handleGetUsage);\n  app.get(\"/usage/\", handleGetUsage);\n  app.get(\"/v1/usage/\", handleGetUsage);\n\n  // ─────────────────────────────────────────────\n  // POST /v1/log-usage & /log-usage\n  // ─────────────────────────────────────────────\n  const handleLogUsage = async (c: any) => {\n    try {\n      const token = extractToken(c.req.raw) || (c as any).get?.(\"apiKey\");\n      let userId = (c as any).get?.(\"userId\");\n\n      if (token) {\n        try {\n          const payload = await verifyToken(token);\n          userId = (payload.sub as string) || userId;\n        } catch {}\n      }\n\n      if (!userId) {\n        return c.json({ error: \"Non authentifié.\" }, 401);\n      }\n\n      const body = await c.req.json().catch(() => ({}));\n      const inputTokens = Number(body.inputTokens || body.promptTokens || 0);\n      const outputTokens = Number(\n        body.outputTokens || body.completionTokens || 0,\n      );\n      const tokensUsed = Number(\n        body.tokensUsed || inputTokens + outputTokens || 0,\n      );\n      const { weekStartStr } = getWeekData();\n\n      const sql = getDb();\n      const userRes =\n        await sql`SELECT id, tier FROM users WHERE id::text = ${userId}::text OR email = ${userId}::text OR username = ${userId}::text LIMIT 1`;\n      const tier = userRes.length > 0 ? userRes[0].tier : \"Free\";\n      const resolvedUserId = userRes.length > 0 ? userRes[0].id : userId;\n      const maiBoost = await getUserQuotaBoost(sql, resolvedUserId, \"mai\");\n      const limit = getTierMaiTokenLimit(tier) + maiBoost;\n\n      const usageResult = await sql`\n        SELECT tokens_used FROM weekly_usage\n        WHERE user_id = ${resolvedUserId}::integer AND week_start = ${weekStartStr}::date\n        LIMIT 1\n      `;\n      const currentUsage = usageResult[0]?.tokens_used || 0;\n\n      await sql`\n        INSERT INTO weekly_usage (user_id, week_start, tokens_used)\n        VALUES (${resolvedUserId}::integer, ${weekStartStr}::date, ${tokensUsed})\n        ON CONFLICT (user_id, week_start)\n        DO UPDATE SET tokens_used = weekly_usage.tokens_used + ${tokensUsed}\n      `;\n\n      return c.json({\n        inputTokens,\n        limit,\n        outputTokens,\n        success: true,\n        tokensUsed,\n        weeklyUsed: currentUsage + tokensUsed,\n      });\n    } catch (err: any) {\n      console.error(\"[log-usage] Error:\", err);\n      return c.json({ error: \"Erreur serveur.\", details: err?.message }, 500);\n    }\n  };\n\n  app.post(\"/log-usage\", handleLogUsage);\n  app.post(\"/v1/log-usage\", handleLogUsage);\n  app.post(\"/log-usage/\", handleLogUsage);\n  app.post(\"/v1/log-usage/\", handleLogUsage);\n\n  // ─────────────────────────────────────────────\n  // GET /v1/models, /models & /v1beta/models\n  // ─────────────────────────────────────────────\n  const handleGetModels = async (c: any) => {\n    const userPlan = c.get(\"userPlan\");\n    const shouldFilterFreeOnly = !isPaidTier(userPlan);\n\n    try {\n      const res = await fetch(\"https://openrouter.ai/api/v1/models\");\n      if (!res.ok) {\n        throw new Error(\"OpenRouter fetch error\");\n      }\n      const json = await res.json();\n      const rawModels: any[] = json.data || [];\n\n      let filtered = rawModels\n        .filter((m) => m && m.id && !m.id.startsWith(\"openrouter/\"))\n        .filter((m) => {\n          const modality = m.architecture?.modality || \"\";\n          const outputModalities = m.architecture?.output_modalities || [];\n          return (\n            outputModalities.includes(\"text\") ||\n            modality.endsWith(\"text\") ||\n            modality.includes(\"->text\")\n          );\n        })\n        .map((m) => ({\n          architecture: m.architecture,\n          created: m.created || Math.floor(Date.now() / 1000),\n          description: m.description || \"\",\n          id: m.id,\n          maxContext: m.context_length || 128_000,\n          maxOutput: m.top_provider?.max_completion_tokens || 4096,\n          name: m.name || m.id,\n          object: \"model\",\n          owned_by: m.id.split(\"/\")[0] || \"openrouter\",\n          supported_parameters: m.supported_parameters || [\n            \"temperature\",\n            \"top_p\",\n            \"max_tokens\",\n            \"stream\",\n            \"stop\",\n            \"tools\",\n            \"response_format\",\n          ],\n        }));\n\n      if (shouldFilterFreeOnly) {\n        filtered = filtered.filter((m) =>\n          (m.id || \"\").toLowerCase().includes(\":free\")\n        );\n      }\n\n      const lagunaIdx = filtered.findIndex((m) =>\n        m.id === \"poolside/laguna-xs-2.1:free\"\n      );\n      if (lagunaIdx > 0) {\n        const [laguna] = filtered.splice(lagunaIdx, 1);\n        filtered.unshift(laguna);\n      }\n\n      return c.json({ data: filtered, object: \"list\" });\n    } catch (_err) {\n      let fallback = [\n        {\n          architecture: {\n            input_modalities: [\"text\"],\n            modality: \"text->text\",\n            output_modalities: [\"text\"],\n          },\n          created: 0,\n          description: \"Modèle IA Laguna XS 2.1 haute performance par Poolside\",\n          id: \"poolside/laguna-xs-2.1:free\",\n          maxContext: 128_000,\n          maxOutput: 4096,\n          name: \"Laguna XS 2.1\",\n          object: \"model\",\n          owned_by: \"poolside\",\n          supported_parameters: [\n            \"temperature\",\n            \"top_p\",\n            \"max_tokens\",\n            \"stream\",\n            \"stop\",\n            \"tools\",\n            \"response_format\",\n          ],\n        },\n        {\n          architecture: {\n            input_modalities: [\"text\", \"image\", \"file\"],\n            modality: \"text+image->text\",\n            output_modalities: [\"text\"],\n          },\n          created: 0,\n          description:\n            \"Modèle multimodal ultra-rapide de Google conçu pour des tâches à haut débit et de raisonnement avec un très grand contexte.\",\n          id: \"google/gemini-2.5-flash:free\",\n          maxContext: 1_048_576,\n          maxOutput: 65_535,\n          name: \"Google: Gemini 2.5 Flash\",\n          object: \"model\",\n          owned_by: \"google\",\n          supported_parameters: [\n            \"temperature\",\n            \"top_p\",\n            \"top_k\",\n            \"max_tokens\",\n            \"tools\",\n            \"response_format\",\n            \"seed\",\n          ],\n        },\n        {\n          architecture: {\n            input_modalities: [\"text\"],\n            modality: \"text->text\",\n            output_modalities: [\"text\"],\n          },\n          created: 0,\n          description:\n            \"Modèle phare de Meta Llama 3.3 70B offrant des compétences avancées de programmation, logique et résolution de problèmes complexes.\",\n          id: \"meta-llama/llama-3.3-70b-instruct:free\",\n          maxContext: 131_072,\n          maxOutput: 128_000,\n          name: \"Meta: Llama 3.3 70B Instruct\",\n          object: \"model\",\n          owned_by: \"meta-llama\",\n          supported_parameters: [\n            \"temperature\",\n            \"top_p\",\n            \"max_tokens\",\n            \"tools\",\n            \"response_format\",\n            \"frequency_penalty\",\n          ],\n        },\n        {\n          architecture: {\n            input_modalities: [\"text\"],\n            modality: \"text->text\",\n            output_modalities: [\"text\"],\n          },\n          created: 0,\n          description:\n            \"Modèle de code spécialisé de haute précision par Alibaba Cloud, optimisé pour la synthèse de code, le refactoring et le debug.\",\n          id: \"qwen/qwen-2.5-coder-32b-instruct:free\",\n          maxContext: 32_768,\n          maxOutput: 8192,\n          name: \"Qwen: Qwen 2.5 Coder 32B Instruct\",\n          object: \"model\",\n          owned_by: \"qwen\",\n          supported_parameters: [\n            \"temperature\",\n            \"top_p\",\n            \"max_tokens\",\n            \"stop\",\n            \"tools\",\n          ],\n        },\n        {\n          architecture: {\n            input_modalities: [\"text\"],\n            modality: \"text->text\",\n            output_modalities: [\"text\"],\n          },\n          created: 0,\n          description:\n            \"Modèle de raisonnement logique étape par étape de premier ordre par DeepSeek pour les mathématiques et la logique complexe.\",\n          id: \"deepseek/deepseek-r1:free\",\n          maxContext: 163_840,\n          maxOutput: 16_000,\n          name: \"DeepSeek: DeepSeek R1\",\n          object: \"model\",\n          owned_by: \"deepseek\",\n          supported_parameters: [\n            \"temperature\",\n            \"top_p\",\n            \"max_tokens\",\n            \"stream\",\n            \"thinking\",\n            \"reasoning\",\n          ],\n        },\n      ];\n\n      if (shouldFilterFreeOnly) {\n        fallback = fallback.filter((m) =>\n          (m.id || \"\").toLowerCase().includes(\":free\")\n        );\n      }\n\n      return c.json({ data: fallback, object: \"list\" });\n    }\n  };\n\n  app.get(\"/v1/models\", handleGetModels);\n  app.get(\"/models\", handleGetModels);\n  app.get(\"/v1beta/models\", handleGetModels);\n\n  // ─────────────────────────────────────────────\n  // GET /v1/models/mai & GET /v1/mai/models\n  // ─────────────────────────────────────────────\n  const handleGetMaiModels = (c: any) => {\n    const formatted = maiModelsList.map((m) => ({\n      capabilities: m.capabilities,\n      context_length: m.contextWindow,\n      created: Math.floor(new Date(m.releaseDate).getTime() / 1000) ||\n        Math.floor(Date.now() / 1000),\n      description: m.description,\n      huggingface_tag: m.huggingFaceTag,\n      id: m.id,\n      license: m.license,\n      max_output_tokens: m.maxOutputTokens,\n      name: m.name,\n      object: \"model\",\n      ollama_tag: m.ollamaTag,\n      owned_by: \"mDevsLabs\",\n      parameters: m.parameters,\n      recommended_hardware: m.recommendedHardware,\n      status: m.status,\n      tagline: m.tagline,\n      usable_in_cloud_chat: false,\n      version: m.version,\n    }));\n    return c.json({ data: formatted, object: \"list\" });\n  };\n\n  app.get(\"/v1/models/mai\", handleGetMaiModels);\n  app.get(\"/v1/mai/models\", handleGetMaiModels);\n  app.get(\"/models/mai\", handleGetMaiModels);\n  app.get(\"/mai/models\", handleGetMaiModels);\n\n  // ─────────────────────────────────────────────\n  // GET /v1/status\n  // ─────────────────────────────────────────────\n  const handleGetStatus = async (c: any) => {\n    try {\n      const res = await fetch(\"https://mai.instatus.com/summary.json\");\n      const data = await res.json();\n      return c.json(data);\n    } catch {\n      return c.json({ error: \"Failed to fetch status\" }, 500);\n    }\n  };\n\n  app.get(\"/v1/status\", handleGetStatus);\n  app.get(\"/status\", handleGetStatus);\n\n  // ─────────────────────────────────────────────\n  // POST /v1/chat/completions & /chat/completions (OpenAI Compatible)\n  // ─────────────────────────────────────────────\n  const handleChatCompletions = async (c: any) => {\n    try {\n      const userPlan = c.get(\"userPlan\") || \"Free\";\n\n      let body: Record;\n      try {\n        body = await c.req.json();\n      } catch {\n        return c.json(\n          {\n            error: {\n              code: \"invalid_request_body\",\n              message: \"Le corps de la requête doit être un JSON valide.\",\n              type: \"invalid_request_error\",\n            },\n          },\n          400,\n        );\n      }\n\n      const modelRequested = body.model;\n      if (!modelRequested) {\n        return c.json(\n          {\n            error: {\n              code: \"missing_model\",\n              message: \"Le paramètre 'model' est obligatoire.\",\n              param: \"model\",\n              type: \"invalid_request_error\",\n            },\n          },\n          400,\n        );\n      }\n      const modelStr = String(modelRequested).toLowerCase().trim();\n\n      // Vérifier si c'est un modèle mAI (local uniquement)\n      const isMaiLocal = modelStr.startsWith(\"mai-\") ||\n        modelStr.startsWith(\"mdevslabs/\") ||\n        modelStr.includes(\"mai-1.\") ||\n        modelStr === \"mai-1\" ||\n        modelStr === \"mai-1-light\";\n\n      if (isMaiLocal) {\n        return c.json(\n          {\n            error: {\n              code: \"mai_model_not_supported_for_cloud_chat\",\n              message:\n                `Le modèle '${modelRequested}' est un modèle mAI destiné à une exécution locale (via Ollama / HuggingFace) et n'est pas directement utilisable en chat completions cloud.`,\n              param: \"model\",\n              type: \"invalid_request_error\",\n            },\n          },\n          400,\n        );\n      }\n\n      const isFreePlan = !isPaidTier(userPlan);\n      const isFreeModel = modelStr.includes(\":free\");\n\n      // Bloquer avec 403 les requêtes pour les modèles payants avec une clé ou JWT free\n      if (isFreePlan && !isFreeModel) {\n        return c.json(\n          {\n            error: {\n              code: \"model_access_denied\",\n              message: `Le modèle '${\n                modelRequested || \"inconnu\"\n              }' nécessite un forfait payant (Plus, Pro ou Max). Votre forfait actuel (${userPlan}) autorise uniquement les modèles contenant ':free' dans leur identifiant (ex: 'google/gemini-2.5-flash:free', 'meta-llama/llama-3.3-70b-instruct:free').`,\n              param: \"model\",\n              type: \"permission_error\",\n            },\n          },\n          403,\n        );\n      }\n\n      let userId = c.get(\"userId\");\n      if (!userId) {\n        const token = extractToken(c.req.raw);\n        if (token) {\n          try {\n            const payload = await verifyToken(token);\n            userId = payload.sub as string;\n          } catch {}\n        }\n      }\n\n      if (!userId) {\n        return c.json({ error: \"Non authentifié.\" }, 401);\n      }\n\n      const sql = getDb();\n      const { weekStartStr } = getWeekData();\n      const usageResult = await sql`\n        SELECT tokens_used FROM weekly_usage\n        WHERE user_id = ${userId}::integer AND week_start = ${weekStartStr}::date\n        LIMIT 1\n      `;\n      const currentUsage = usageResult[0]?.tokens_used || 0;\n      const maiBoost = await getUserQuotaBoost(sql, userId, \"mai\");\n      const limit = getTierMaiTokenLimit(userPlan) + maiBoost;\n\n      if (currentUsage >= limit) {\n        return c.json(\n          { error: \"Votre limite hebdomadaire est épuisée. Quota atteint.\" },\n          429,\n        );\n      }\n\n      const keyRows = await sql`\n        SELECT api_key FROM mprojects_api_keys WHERE user_id::text = ${userId}::text LIMIT 1\n      `;\n      const apiKey = getOpenRouterApiKey(\n        keyRows.length > 0 ? keyRows[0].api_key : null,\n      );\n\n      if (!apiKey) {\n        return c.json({ error: \"Clé fournisseur OpenRouter manquante.\" }, 500);\n      }\n\n      // Nettoyer le body : retirer tout champ `api_key` ou `Authorization` injecté par le client\n      // pour empêcher tout contournement de la clé serveur.\n      const {\n        api_key: _ck,\n        authorization: _ca,\n        Authorization: _cA,\n        ...safeBody\n      } = body as Record;\n\n      const openRouterRes = await fetch(\n        \"https://openrouter.ai/api/v1/chat/completions\",\n        {\n          body: JSON.stringify(safeBody),\n          headers: {\n            Authorization: `Bearer ${apiKey}`,\n            \"Content-Type\": \"application/json\",\n            \"HTTP-Referer\": \"https://mai.val.run\",\n            \"X-Title\": \"mAI Public API\",\n          },\n          method: \"POST\",\n        },\n      );\n\n      if (openRouterRes.status === 200) {\n        try {\n          await sql`\n            INSERT INTO weekly_usage (user_id, week_start, tokens_used)\n            VALUES (${userId}::integer, ${weekStartStr}::date, 1)\n            ON CONFLICT (user_id, week_start)\n            DO UPDATE SET tokens_used = weekly_usage.tokens_used + 1\n          `;\n        } catch (_e) {}\n      }\n\n      return new Response(openRouterRes.body, {\n        headers: {\n          \"Content-Type\": openRouterRes.headers.get(\"Content-Type\") ||\n            \"application/json\",\n        },\n        status: openRouterRes.status,\n      });\n    } catch (err: any) {\n      console.error(\"[ChatCompletions] Erreur inattendue:\", err);\n      return c.json(\n        {\n          details: err?.message || \"Erreur interne.\",\n          error: \"Failed to process chat completion.\",\n        },\n        500,\n      );\n    }\n  };\n\n  app.post(\"/v1/chat/completions\", handleChatCompletions);\n  app.post(\"/chat/completions\", handleChatCompletions);\n\n  // ─────────────────────────────────────────────\n  // POST /v1/messages & /messages (Proxy Anthropic SDK)\n  // ─────────────────────────────────────────────\n  const handleMessages = async (c: any) => {\n    try {\n      const userPlan = c.get(\"userPlan\") || \"Free\";\n\n      let body: Record;\n      try {\n        body = await c.req.json();\n      } catch {\n        return c.json(\n          {\n            error: {\n              code: \"invalid_request_body\",\n              message: \"Le corps de la requête doit être un JSON valide.\",\n              type: \"invalid_request_error\",\n            },\n          },\n          400,\n        );\n      }\n\n      const modelRequested = body.model;\n      const modelStr = String(modelRequested || \"\").toLowerCase().trim();\n\n      const isFreePlan = !isPaidTier(userPlan);\n      const isFreeModel = modelStr.includes(\":free\");\n\n      // Bloquer avec 403 les requêtes pour les modèles payants avec une clé ou JWT free\n      if (isFreePlan && !isFreeModel) {\n        return c.json(\n          {\n            error: {\n              code: \"model_access_denied\",\n              message: `Le modèle '${\n                modelRequested || \"inconnu\"\n              }' nécessite un forfait payant (Plus, Pro ou Max). Votre forfait actuel (${userPlan}) autorise uniquement les modèles gratuits dont l'ID contient ':free' (ex: 'meta-llama/llama-3.3-70b-instruct:free', 'deepseek/deepseek-r1:free').`,\n              param: \"model\",\n              type: \"permission_error\",\n            },\n          },\n          403,\n        );\n      }\n\n      let userId = c.get(\"userId\");\n      if (!userId) {\n        const token = extractToken(c.req.raw);\n        if (token) {\n          try {\n            const payload = await verifyToken(token);\n            userId = payload.sub as string;\n          } catch {}\n        }\n      }\n\n      if (!userId) {\n        return c.json({ error: \"Non authentifié.\" }, 401);\n      }\n\n      const sql = getDb();\n      const { weekStartStr } = getWeekData();\n      const usageResult = await sql`\n        SELECT tokens_used FROM weekly_usage\n        WHERE user_id = ${userId}::integer AND week_start = ${weekStartStr}::date\n        LIMIT 1\n      `;\n      const currentUsage = usageResult[0]?.tokens_used || 0;\n      const maiBoost = await getUserQuotaBoost(sql, userId, \"mai\");\n      const limit = getTierMaiTokenLimit(userPlan) + maiBoost;\n\n      if (currentUsage >= limit) {\n        return c.json(\n          { error: \"Votre limite hebdomadaire est épuisée. Quota atteint.\" },\n          429,\n        );\n      }\n\n      const keyRows = await sql`\n        SELECT api_key FROM mprojects_api_keys WHERE user_id::text = ${userId}::text LIMIT 1\n      `;\n      const apiKey = getOpenRouterApiKey(\n        keyRows.length > 0 ? keyRows[0].api_key : null,\n      );\n\n      if (!apiKey) {\n        return c.json({ error: \"Clé fournisseur OpenRouter manquante.\" }, 500);\n      }\n\n      // Nettoyer le body : retirer tout champ `api_key` ou `Authorization` injecté par le client\n      const {\n        api_key: _ck,\n        authorization: _ca,\n        Authorization: _cA,\n        ...safeBody\n      } = body as Record;\n\n      const openRouterRes = await fetch(\n        \"https://openrouter.ai/api/v1/chat/completions\",\n        {\n          body: JSON.stringify(safeBody),\n          headers: {\n            Authorization: `Bearer ${apiKey}`,\n            \"Content-Type\": \"application/json\",\n            \"HTTP-Referer\": \"https://mai.val.run\",\n            \"X-Title\": \"mAI Public API (Anthropic)\",\n          },\n          method: \"POST\",\n        },\n      );\n\n      if (openRouterRes.status === 200) {\n        try {\n          await sql`\n            INSERT INTO weekly_usage (user_id, week_start, tokens_used)\n            VALUES (${userId}::integer, ${weekStartStr}::date, 1)\n            ON CONFLICT (user_id, week_start)\n            DO UPDATE SET tokens_used = weekly_usage.tokens_used + 1\n          `;\n        } catch (_e) {}\n      }\n\n      return new Response(openRouterRes.body, {\n        headers: {\n          \"Content-Type\": openRouterRes.headers.get(\"Content-Type\") ||\n            \"application/json\",\n        },\n        status: openRouterRes.status,\n      });\n    } catch (err: any) {\n      console.error(\"[Messages] Erreur inattendue:\", err);\n      return c.json(\n        {\n          details: err?.message || \"Erreur interne.\",\n          error: \"Failed to process Anthropic request.\",\n        },\n        500,\n      );\n    }\n  };\n\n  app.post(\"/v1/messages\", handleMessages);\n  app.post(\"/messages\", handleMessages);\n\n  // ─────────────────────────────────────────────\n  // POST /v1beta/models/* & /v1/models/* (Proxy Google Gemini SDK)\n  // ─────────────────────────────────────────────\n  const handleGeminiGenerate = async (c: any) => {\n    try {\n      const userPlan = c.get(\"userPlan\") || \"Free\";\n\n      // Pour Gemini, le body JSON peut être optionnel (le modèle est dans l'URL)\n      let body: Record = {};\n      try {\n        body = await c.req.json();\n      } catch {\n        // body vide acceptable pour Gemini (modèle dans le path)\n      }\n\n      const fullPath = c.req.path;\n      // Extraire le modèle depuis l'URL (ex: /v1beta/models/google/gemini-2.5-flash:free:generateContent -> google/gemini-2.5-flash:free)\n      const pathModel = fullPath\n        .replace(/^\\/(v1beta|v1)\\/models\\//, \"\")\n        .replace(/:(generateContent|streamGenerateContent).*$/, \"\");\n\n      const paramModel = c.req.param(\"model\");\n      const modelRequested = body.model || paramModel || pathModel;\n      const modelStr = String(modelRequested || \"\").toLowerCase().trim();\n\n      const isFreePlan = !isPaidTier(userPlan);\n      const isFreeModel = modelStr.includes(\":free\");\n\n      // Bloquer avec 403 les requêtes pour les modèles payants avec une clé ou JWT free\n      if (isFreePlan && !isFreeModel) {\n        return c.json(\n          {\n            error: {\n              code: 403,\n              message: `Le modèle '${\n                modelRequested || \"inconnu\"\n              }' nécessite un forfait payant (Plus, Pro ou Max). Votre forfait actuel (${userPlan}) autorise uniquement les modèles gratuits contenant ':free' dans leur identifiant (ex: 'google/gemini-2.5-flash:free').`,\n              status: \"PERMISSION_DENIED\",\n            },\n          },\n          403,\n        );\n      }\n\n      let userId = c.get(\"userId\");\n      if (!userId) {\n        const token = extractToken(c.req.raw);\n        if (token) {\n          try {\n            const payload = await verifyToken(token);\n            userId = payload.sub as string;\n          } catch {}\n        }\n      }\n\n      if (!userId) {\n        return c.json({ error: \"Non authentifié.\" }, 401);\n      }\n\n      const sql = getDb();\n      const { weekStartStr } = getWeekData();\n      const usageResult = await sql`\n        SELECT tokens_used FROM weekly_usage\n        WHERE user_id = ${userId}::integer AND week_start = ${weekStartStr}::date\n        LIMIT 1\n      `;\n      const currentUsage = usageResult[0]?.tokens_used || 0;\n      const maiBoost = await getUserQuotaBoost(sql, userId, \"mai\");\n      const limit = getTierMaiTokenLimit(userPlan) + maiBoost;\n\n      if (currentUsage >= limit) {\n        return c.json(\n          { error: \"Votre limite hebdomadaire est épuisée. Quota atteint.\" },\n          429,\n        );\n      }\n\n      const keyRows = await sql`\n        SELECT api_key FROM mprojects_api_keys WHERE user_id::text = ${userId}::text LIMIT 1\n      `;\n      const apiKey = getOpenRouterApiKey(\n        keyRows.length > 0 ? keyRows[0].api_key : null,\n      );\n\n      if (!apiKey) {\n        return c.json({ error: \"Clé fournisseur OpenRouter manquante.\" }, 500);\n      }\n\n      // Nettoyer le body : retirer tout champ `api_key` ou `Authorization` injecté par le client\n      const {\n        api_key: _ck,\n        authorization: _ca,\n        Authorization: _cA,\n        ...safeBody\n      } = body as Record;\n\n      const openRouterPayload = {\n        ...safeBody,\n        model: body.model || modelRequested,\n      };\n\n      const openRouterRes = await fetch(\n        \"https://openrouter.ai/api/v1/chat/completions\",\n        {\n          body: JSON.stringify(openRouterPayload),\n          headers: {\n            Authorization: `Bearer ${apiKey}`,\n            \"Content-Type\": \"application/json\",\n            \"HTTP-Referer\": \"https://mai.val.run\",\n            \"X-Title\": \"mAI Public API (Gemini)\",\n          },\n          method: \"POST\",\n        },\n      );\n\n      if (openRouterRes.status === 200) {\n        try {\n          await sql`\n            INSERT INTO weekly_usage (user_id, week_start, tokens_used)\n            VALUES (${userId}::integer, ${weekStartStr}::date, 1)\n            ON CONFLICT (user_id, week_start)\n            DO UPDATE SET tokens_used = weekly_usage.tokens_used + 1\n          `;\n        } catch (_e) {}\n      }\n\n      return new Response(openRouterRes.body, {\n        headers: {\n          \"Content-Type\": openRouterRes.headers.get(\"Content-Type\") ||\n            \"application/json\",\n        },\n        status: openRouterRes.status,\n      });\n    } catch (err: any) {\n      console.error(\"[GeminiGenerate] Erreur inattendue:\", err);\n      return c.json(\n        {\n          details: err?.message || \"Erreur interne.\",\n          error: \"Failed to process Google Gemini request.\",\n        },\n        500,\n      );\n    }\n  };\n\n  app.post(\"/v1beta/models/*\", handleGeminiGenerate);\n  app.post(\"/v1/models/*:generateContent\", handleGeminiGenerate);\n  app.post(\"/v1/models/*:streamGenerateContent\", handleGeminiGenerate);\n}",[118],"d28aa131-3dbf-4246-bbf8-1a339dada4c2","main.ts",257,["D",1788714800578],54,"http","/**\n * mAI — Backend & API Routes\n * Base URL : https://mai.val.run\n */\n\nimport { cors } from \"npm:hono/cors\";\nimport { Hono } from \"npm:hono@4\";\nimport { registerAuthRoutes } from \"./auth.ts\";\nimport { registerAudioRoutes } from \"./audio.ts\";\nimport { initSQLite } from \"./config.ts\";\nimport { registerDeviceRoutes } from \"./devices.ts\";\nimport { registerImageRoutes } from \"./images.ts\";\nimport { registerMiddleware } from \"./api-middleware.ts\";\nimport { registerModelRoutes } from \"./models.ts\";\nimport { registerProjectRoutes } from \"./projects.ts\";\nimport { registerRealtimeRoutes } from \"./realtime.ts\";\nimport { registerStorageRoutes } from \"./storage.ts\";\nimport { registerTranslateRoutes } from \"./translate.ts\";\nimport { registerVibeAIRoutes } from \"./vibe-ai.ts\";\nimport { registerVibeRoutes } from \"./vibe.ts\";\nimport { registerWebRoutes } from \"./web.ts\";\n\n// ─────────────────────────────────────────────\n// Init DB SQLite en background\n// ─────────────────────────────────────────────\ninitSQLite().catch(console.error);\n\n// ─────────────────────────────────────────────\n// App Hono\n// ─────────────────────────────────────────────\nconst app = new Hono();\n\n// ─────────────────────────────────────────────\n// CORS ouvert : toutes les origines acceptées (tests local / preview / prod temporaire)\n// ─────────────────────────────────────────────\n\napp.use(\n  \"*\",\n  cors({\n    origin: \"*\",\n    // \"*\" impose credentials: false (spec navigateur). Le frontend\n    // utilise Authorization Bearer (src/services/api.ts), pas de cookies.\n    credentials: false,\n    allowMethods: [\"GET\", \"POST\", \"PUT\", \"DELETE\", \"PATCH\", \"OPTIONS\", \"HEAD\"],\n    allowHeaders: [\n      // Standards fetch / navigateur\n      \"Accept\",\n      \"Accept-Language\",\n      \"Content-Language\",\n      \"Content-Type\",\n      \"Content-Length\",\n      \"Content-Disposition\",\n      \"Range\",\n      \"Origin\",\n      \"Referer\",\n      \"X-Requested-With\",\n      \"DNT\",\n      \"Cache-Control\",\n      \"Pragma\",\n      \"Expires\",\n      \"If-Modified-Since\",\n      \"If-None-Match\",\n      \"If-Match\",\n      // Auth / API maison (api-middleware.ts, audio.ts, images.ts)\n      \"Authorization\",\n      \"x-user-id\",\n      \"X-User-Id\",\n      \"x-api-key\",\n      \"X-API-Key\",\n      \"x-goog-api-key\",\n      \"X-Goog-Api-Key\",\n      // Custom app (web.ts)\n      \"x-web-search\",\n      \"X-Web-Search\",\n      \"x-disable-web-search\",\n      \"X-Disable-Web-Search\",\n      // SDK Anthropic / OpenAI / OpenRouter compatibles\n      \"anthropic-version\",\n      \"anthropic-beta\",\n      \"anthropic-dangerous-direct-browser-access\",\n      \"OpenAI-Organization\",\n      \"OpenAI-Project\",\n      \"X-Title\",\n      \"HTTP-Referer\",\n      \"X-Request-Id\",\n      \"X-Client-Info\",\n      \"apikey\",\n      \"x-client-version\",\n      \"x-app-version\",\n      \"X-Stripe-Signature\",\n    ],\n    exposeHeaders: [\n      \"Content-Type\",\n      \"Authorization\",\n      \"x-user-id\",\n      \"x-audio-id\",\n      \"x-speech-limit\",\n      \"x-speech-used\",\n      \"x-tokens-used\",\n      \"Content-Length\",\n      \"Content-Range\",\n      \"ETag\",\n    ],\n    maxAge: 86_400,\n  }),\n);\n\n// Filet preflight explicite : répond 204 avant l'auth (local / preview / SDK).\napp.options(\"*\", (c) => c.text(\"\", 204));\n\napp.use(\"*\", async (c, next) => {\n  await next();\n  c.header(\"X-Content-Type-Options\", \"nosniff\");\n  c.header(\"Referrer-Policy\", \"strict-origin-when-cross-origin\");\n  c.header(\"X-Frame-Options\", \"DENY\");\n  c.header(\n    \"Permissions-Policy\",\n    \"camera=(), geolocation=(), microphone=(self)\",\n  );\n});\n\n// ─────────────────────────────────────────────\n// ROUTE RACINE : mAI UNIQUEMENT (URL de base de l'API)\n// ─────────────────────────────────────────────\napp.get(\"/\", (c) => c.text(\"mAI\"));\napp.get(\"/api\", (c) => c.text(\"mAI\"));\napp.get(\"/api/\", (c) => c.text(\"mAI\"));\napp.get(\"/v1\", (c) => c.text(\"mAI\"));\napp.get(\"/v1/\", (c) => c.text(\"mAI\"));\napp.get(\"/vibe\", (c) => c.text(\"mAI\"));\napp.get(\"/vibe/\", (c) => c.text(\"mAI\"));\napp.get(\"/api/vibe\", (c) => c.text(\"mAI\"));\napp.get(\"/api/vibe/\", (c) => c.text(\"mAI\"));\n\n// ─────────────────────────────────────────────\n// Middleware & Routes modulaires\n// ─────────────────────────────────────────────\nregisterMiddleware(app);\nregisterAuthRoutes(app);\nregisterStorageRoutes(app);\nregisterModelRoutes(app);\nregisterImageRoutes(app);\nregisterAudioRoutes(app);\nregisterWebRoutes(app);\nregisterProjectRoutes(app);\nregisterDeviceRoutes(app);\nregisterRealtimeRoutes(app);\nregisterVibeAIRoutes(app);\nregisterTranslateRoutes(app);\nregisterVibeRoutes(app);\n\nexport default app.fetch;",[650],"be398c28-d1fb-4c60-9f77-01436ae5c7db","maiModels.ts","d2e49b4e-9fd5-11f1-866a-1607ee4eb77e",["D",1787587613987],"export interface MAIModelDetail {\n  capabilities: {\n    coding: boolean;\n    reasoning: boolean;\n    vision: boolean;\n    jsonOutput: boolean;\n    functionCalling: boolean;\n  };\n  contextWindow: number;\n  description: string;\n  huggingFaceTag: string;\n  id: string;\n  license: string;\n  maxOutputTokens: number;\n  multimodal: boolean;\n  name: string;\n  ollamaTag: string;\n  parameters: string;\n  recommendedHardware: {\n    minVram: string;\n    recommendedVram: string;\n    ram: string;\n  };\n  releaseDate: string;\n  status: \"active\" | \"beta\" | \"deprecated\";\n  tagline: string;\n  version: string;\n  vision: boolean;\n}\n\nexport const maiModelsList: MAIModelDetail[] = [\n  {\n    capabilities: {\n      coding: true,\n      functionCalling: true,\n      jsonOutput: true,\n      reasoning: true,\n      vision: true,\n    },\n    contextWindow: 262_144,\n    description:\n      \"Modèle léger de 4 milliards de paramètres conçu pour une agilité maximale sur machines personnelles avec vision intégrée, capacité de raisonnement (thinking) et gestion avancée des appels d'outils (tools).\",\n    huggingFaceTag: \"mDevsLabs/mAI-1.5-Light\",\n    id: \"mai-1.5-light\",\n    license: \"MIT\",\n    maxOutputTokens: 32_768,\n    multimodal: true,\n    name: \"mAI-1.5-Light\",\n    ollamaTag: \"mDevsLabs/mAI-1.5-Light\",\n    parameters: \"4B\",\n    recommendedHardware: {\n      minVram: \"4GB\",\n      ram: \"8GB\",\n      recommendedVram: \"8GB\",\n    },\n    releaseDate: \"2026-08-28\",\n    status: \"active\",\n    tagline:\n      \"Assistant IA local ultra-rapide et multimodal. Vision intégrée, raisonnement (thinking) et appels d'outils (tools).\",\n    version: \"1.5.0\",\n    vision: true,\n  },\n  {\n    capabilities: {\n      coding: true,\n      functionCalling: true,\n      jsonOutput: true,\n      reasoning: true,\n      vision: true,\n    },\n    contextWindow: 262_144,\n    description:\n      \"Modèle d'élite de 9 milliards de paramètres offrant des performances d'analyse logique et de programmation exceptionnelles, avec support natif du raisonnement profond (thinking), de la vision et des appels d'outils.\",\n    huggingFaceTag: \"mDevsLabs/mAI-1.5-Apex\",\n    id: \"mai-1.5-apex\",\n    license: \"MIT\",\n    maxOutputTokens: 32_768,\n    multimodal: true,\n    name: \"mAI-1.5-Apex\",\n    ollamaTag: \"mDevsLabs/mAI-1.5-Apex\",\n    parameters: \"9B\",\n    recommendedHardware: {\n      minVram: \"8GB\",\n      ram: \"16GB\",\n      recommendedVram: \"16GB\",\n    },\n    releaseDate: \"2026-08-28\",\n    status: \"active\",\n    tagline:\n      \"Le haut de gamme absolu de la famille mAI. Puissance maximale, vision multimodale, raisonnement complexe et tools.\",\n    version: \"1.5.0\",\n    vision: true,\n  },\n  {\n    capabilities: {\n      coding: true,\n      functionCalling: true,\n      jsonOutput: true,\n      reasoning: true,\n      vision: true,\n    },\n    contextWindow: 262_144,\n    description:\n      \"Modèle 27B polyvalent et surpuissant pour postes de travail et serveurs locaux, réunissant vision multimodale, raisonnement étape par étape et intégration fluide des API et outils externes.\",\n    huggingFaceTag: \"mDevsLabs/mAI-1.5-Opal\",\n    id: \"mai-1.5-opal\",\n    license: \"MIT\",\n    maxOutputTokens: 32_768,\n    multimodal: true,\n    name: \"mAI-1.5-Opal\",\n    ollamaTag: \"mDevsLabs/mAI-1.5-Opal\",\n    parameters: \"27B\",\n    recommendedHardware: {\n      minVram: \"16GB\",\n      ram: \"32GB\",\n      recommendedVram: \"24GB\",\n    },\n    releaseDate: \"2026-08-28\",\n    status: \"active\",\n    tagline:\n      \"L'équilibre parfait entre haute intelligence et vélocité. Multimodal 27B avec vision, thinking et tools.\",\n    version: \"1.5.0\",\n    vision: true,\n  },\n  {\n    capabilities: {\n      coding: true,\n      functionCalling: true,\n      jsonOutput: true,\n      reasoning: true,\n      vision: true,\n    },\n    contextWindow: 262_144,\n    description:\n      \"Modèle léger de 3 milliards de paramètres conçu pour une exécution ultra-rapide sur laptops et machines personnelles avec accélération vision intégrée.\",\n    huggingFaceTag: \"mDevsLabs/mAI-1.2-Light-GGUF\",\n    id: \"mai-1.2-light\",\n    license: \"MIT\",\n    maxOutputTokens: 16_384,\n    multimodal: true,\n    name: \"mAI-1.2-Light\",\n    ollamaTag: \"mDevsLabs/mAI-1.2-Light\",\n    parameters: \"3B\",\n    recommendedHardware: {\n      minVram: \"4GB\",\n      ram: \"8GB\",\n      recommendedVram: \"8GB\",\n    },\n    releaseDate: \"2026-07-22\",\n    status: \"active\",\n    tagline:\n      \"Assistant IA local ultra-rapide et multimodal. Légèreté maximale, vision intégrée.\",\n    version: \"1.2.0\",\n    vision: true,\n  },\n  {\n    capabilities: {\n      coding: true,\n      functionCalling: true,\n      jsonOutput: true,\n      reasoning: true,\n      vision: true,\n    },\n    contextWindow: 262_144,\n    description:\n      \"Modèle phare de 9 milliards de paramètres offrant un raisonnement logique complexe, des compétences en développement logiciel et une analyse d'images de haute précision.\",\n    huggingFaceTag: \"mDevsLabs/mAI-1.2-Apex-GGUF\",\n    id: \"mai-1.2-apex\",\n    license: \"MIT\",\n    maxOutputTokens: 32_768,\n    multimodal: true,\n    name: \"mAI-1.2-Apex\",\n    ollamaTag: \"mDevsLabs/mAI-1.2-Apex\",\n    parameters: \"9B\",\n    recommendedHardware: {\n      minVram: \"8GB\",\n      ram: \"16GB\",\n      recommendedVram: \"16GB\",\n    },\n    releaseDate: \"2026-07-22\",\n    status: \"active\",\n    tagline:\n      \"Le top tier de la famille mAI-1.2. Performances maximales, vision et raisonnement avancé.\",\n    version: \"1.2.0\",\n    vision: true,\n  },\n  {\n    capabilities: {\n      coding: true,\n      functionCalling: true,\n      jsonOutput: true,\n      reasoning: true,\n      vision: false,\n    },\n    contextWindow: 262_144,\n    description:\n      \"Modèle 33B polyvalent pour serveurs locaux et postes de travail spécialisés, offrant un équilibre exceptionnel pour la rédaction, la programmation et l'analyse documentaire.\",\n    huggingFaceTag: \"mDevsLabs/mAI-1.2-Opal-GGUF\",\n    id: \"mai-1.2-opal\",\n    license: \"MIT\",\n    maxOutputTokens: 32_768,\n    multimodal: false,\n    name: \"mAI-1.2-Opal\",\n    ollamaTag: \"mDevsLabs/mAI-1.2-Opal\",\n    parameters: \"33B\",\n    recommendedHardware: {\n      minVram: \"16GB\",\n      ram: \"32GB\",\n      recommendedVram: \"24GB\",\n    },\n    releaseDate: \"2026-07-22\",\n    status: \"active\",\n    tagline:\n      \"Le sweet spot parfait entre vitesse et intelligence élevée. Équilibré et fluide.\",\n    version: \"1.2.0\",\n    vision: false,\n  },\n  {\n    capabilities: {\n      coding: true,\n      functionCalling: false,\n      jsonOutput: true,\n      reasoning: true,\n      vision: true,\n    },\n    contextWindow: 262_144,\n    description:\n      \"Première génération du modèle mAI 12B avec support multimodal original et capacités avancées en résolution de problèmes.\",\n    huggingFaceTag: \"mDevsLabs/mAI-1-GGUF\",\n    id: \"mai-1\",\n    license: \"MIT\",\n    maxOutputTokens: 16_384,\n    multimodal: true,\n    name: \"mAI-1\",\n    ollamaTag: \"mDevsLabs/mAI-1\",\n    parameters: \"12B\",\n    recommendedHardware: {\n      minVram: \"8GB\",\n      ram: \"16GB\",\n      recommendedVram: \"12GB\",\n    },\n    releaseDate: \"2026-07-11\",\n    status: \"active\",\n    tagline:\n      \"Assistant IA local multimodal puissant de 12B paramètres pour le raisonnement et le code.\",\n    version: \"1.0.0\",\n    vision: true,\n  },\n  {\n    capabilities: {\n      coding: true,\n      functionCalling: false,\n      jsonOutput: true,\n      reasoning: true,\n      vision: false,\n    },\n    contextWindow: 131_072,\n    description:\n      \"Version 3B texte de première génération optimisée pour une empreinte mémoire minimale.\",\n    huggingFaceTag: \"mDevsLabs/mAI-1-Light-GGUF\",\n    id: \"mai-1-light\",\n    license: \"MIT\",\n    maxOutputTokens: 8192,\n    multimodal: false,\n    name: \"mAI-1-Light\",\n    ollamaTag: \"mDevsLabs/mAI-1-Light\",\n    parameters: \"3B\",\n    recommendedHardware: {\n      minVram: \"2GB\",\n      ram: \"8GB\",\n      recommendedVram: \"4GB\",\n    },\n    releaseDate: \"2026-07-11\",\n    status: \"active\",\n    tagline: \"Assistant IA local ultraléger et rapide de 3B paramètres.\",\n    version: \"1.0.0\",\n    vision: false,\n  },\n];\n\nexport const maiModels = maiModelsList;",[658],"01b444a4-db1c-486c-9c4c-3d111a9ed347",["D",1788164141214],[135],"89ae05b3-5270-44cc-bd4a-2a9f00ac21db",["D",1788618643754],[151],"af695e83-f648-44f3-bd53-f7a6fbe86e93","devices.ts","e97247d0-9c6a-11f1-8111-1607ee4eb77e",["D",1787754938926],"import { sqlite } from \"https://esm.town/v/std/sqlite\";\nimport type { Hono } from \"npm:hono@4\";\nimport { extractToken, getDb, parseUserAgent } from \"./config.ts\";\n\nexport function registerDeviceRoutes(app: Hono) {\n  // GET /v1/devices\n  app.get(\"/v1/devices\", async (c) => {\n    const userId = c.get(\"userId\");\n    const token = extractToken(c.req.raw);\n    const sql = getDb();\n\n    const existing =\n      await sql`SELECT id FROM connected_devices WHERE token = ${token}`;\n    if (existing.length === 0) {\n      const userAgent = c.req.header(\"user-agent\") || \"\";\n      const ip = c.req.header(\"cf-connecting-ip\") ||\n        c.req.header(\"x-forwarded-for\") ||\n        \"Inconnue\";\n      const { os, device_model, device_version, device_name } = parseUserAgent(\n        userAgent,\n      );\n      try {\n        await sql`\n          INSERT INTO connected_devices (user_id, token, os, device_model, device_version, ip_address, device_name)\n          VALUES (${userId}::text, ${token}, ${os}, ${device_model}, ${device_version}, ${ip}, ${device_name})\n        `;\n      } catch (err) {\n        console.error(\"Auto-insert device error:\", err);\n      }\n    } else {\n      try {\n        await sql`UPDATE connected_devices SET last_active = NOW() WHERE token = ${token}`;\n      } catch (_err) {}\n    }\n\n    const rawDevices = await sql`\n      SELECT id, token, os, device_model, device_version, ip_address, device_name, last_active, created_at \n      FROM connected_devices \n      WHERE user_id = ${userId}::text \n      ORDER BY last_active DESC\n    `;\n\n    const devices = rawDevices.map((d: any) => ({\n      created_at: d.created_at,\n      device_model: d.device_model,\n      device_name: d.device_name,\n      device_version: d.device_version || \"\",\n      id: d.id,\n      ip_address: d.ip_address,\n      is_current: d.token === token,\n      last_active: d.last_active,\n      os: d.os,\n    }));\n\n    return c.json({ devices, success: true });\n  });\n\n  // DELETE /v1/devices/others\n  app.delete(\"/v1/devices/others\", async (c) => {\n    const userId = c.get(\"userId\");\n    const token = extractToken(c.req.raw);\n    const sql = getDb();\n\n    const otherDevices = await sql`\n      SELECT token FROM connected_devices \n      WHERE user_id = ${userId}::text AND token != ${token}\n    `;\n\n    for (const row of otherDevices) {\n      if (row.token) {\n        try {\n          await sqlite.execute({\n            args: [row.token],\n            sql: \"INSERT OR IGNORE INTO token_blacklist (token) VALUES (?)\",\n          });\n        } catch (_e) {}\n      }\n    }\n\n    await sql`\n      DELETE FROM connected_devices \n      WHERE user_id = ${userId}::text AND token != ${token}\n    `;\n\n    return c.json({\n      message: \"Tous les autres appareils ont été déconnectés.\",\n      success: true,\n    });\n  });\n\n  // DELETE /v1/devices/all\n  app.delete(\"/v1/devices/all\", async (c) => {\n    const userId = c.get(\"userId\");\n    const sql = getDb();\n\n    const allDevices = await sql`\n      SELECT token FROM connected_devices \n      WHERE user_id = ${userId}::text\n    `;\n\n    for (const row of allDevices) {\n      if (row.token) {\n        try {\n          await sqlite.execute({\n            args: [row.token],\n            sql: \"INSERT OR IGNORE INTO token_blacklist (token) VALUES (?)\",\n          });\n        } catch (_e) {}\n      }\n    }\n\n    await sql`\n      DELETE FROM connected_devices \n      WHERE user_id = ${userId}::text\n    `;\n\n    return c.json({\n      message: \"Tous les appareils ont été déconnectés.\",\n      success: true,\n    });\n  });\n\n  // PUT /v1/devices/:id\n  app.put(\"/v1/devices/:id\", async (c) => {\n    const userId = c.get(\"userId\");\n    const deviceId = c.req.param(\"id\");\n    const { device_name } = await c.req.json();\n    const sql = getDb();\n    await sql`UPDATE connected_devices SET device_name = ${device_name} WHERE id = ${deviceId} AND user_id = ${userId}::text`;\n    return c.json({ success: true });\n  });\n\n  // DELETE /v1/devices/:id\n  app.delete(\"/v1/devices/:id\", async (c) => {\n    const userId = c.get(\"userId\");\n    const deviceId = c.req.param(\"id\");\n    const sql = getDb();\n\n    const devices =\n      await sql`SELECT token FROM connected_devices WHERE id = ${deviceId} AND user_id = ${userId}::text LIMIT 1`;\n    if (devices.length > 0) {\n      const token = devices[0].token;\n      if (token) {\n        await sqlite.execute({\n          args: [token],\n          sql: \"INSERT OR IGNORE INTO token_blacklist (token) VALUES (?)\",\n        });\n      }\n      await sql`DELETE FROM connected_devices WHERE id = ${deviceId}`;\n    }\n    return c.json({ success: true });\n  });\n}",[670],"c525f4f7-c89d-42a4-92c2-60d867a7e18a",["D",1788618643754],"import { sqlite } from \"https://esm.town/v/std/sqlite\";\nimport { neon } from \"npm:@neondatabase/serverless\";\nimport { jwtVerify, SignJWT } from \"npm:jose\";\n\n// ─────────────────────────────────────────────\n// Config & Données\n// ─────────────────────────────────────────────\nexport const JWT_EXPIRY = \"7d\";\nexport const BCRYPT_ROUNDS = 12;\n\n// ─────────────────────────────────────────────\n// Rate limiting en mémoire (par clé : ip ou user)\n// ─────────────────────────────────────────────\nconst rateBuckets = new Map();\n\nexport function rateLimit(\n  key: string,\n  limit: number,\n  windowMs: number,\n): boolean {\n  const now = Date.now();\n  const bucket = rateBuckets.get(key);\n  if (!bucket || now > bucket.resetAt) {\n    rateBuckets.set(key, { count: 1, resetAt: now + windowMs });\n    return true;\n  }\n  if (bucket.count >= limit) return false;\n  bucket.count += 1;\n  return true;\n}\n\nexport function clientIp(c: any): string {\n  return (\n    c.req.header(\"x-forwarded-for\")?.split(\",\")[0]?.trim() ||\n    c.req.header(\"x-real-ip\") ||\n    \"unknown\"\n  );\n}\n\nexport type Tier = \"Free\" | \"Plus\" | \"Pro\" | \"Max\";\n\nconst TIER_ALIASES: Record = {\n  free: \"Free\",\n  gratuit: \"Free\",\n  plus: \"Plus\",\n  pro: \"Pro\",\n  max: \"Max\",\n};\n\n/**\n * Normalise n'importe quelle représentation de forfait venant de la base, d'une clé API\n * ou d'un JWT (\"gratuit\", \" PRO \", \"max\") en tier canonique.\n * Une valeur vide ou inconnue retombe sur \"Free\", comme l'ancien `MAP[t] || MAP[\"Free\"]`.\n */\nexport function normalizeTier(tier?: string | null): Tier {\n  return TIER_ALIASES[String(tier || \"\").trim().toLowerCase()] || \"Free\";\n}\n\nexport function isPaidTier(tier?: string | null): boolean {\n  return normalizeTier(tier) !== \"Free\";\n}\n\n// Limites de tokens mAI hebdomadaires (Input + Output)\nexport const TIER_LIMITS: Record = {\n  Free: 10_000_000,\n  Plus: 20_000_000,\n  Pro: 30_000_000,\n  Max: 50_000_000,\n};\n\nexport function getTierMaiTokenLimit(tier?: string | null): number {\n  return TIER_LIMITS[normalizeTier(tier)];\n}\n\n// Limites de tokens Speech hebdomadaires\nexport const TIER_SPEECH_LIMITS: Record = {\n  Free: 30_000_000,\n  Plus: 75_000_000,\n  Pro: 150_000_000,\n  Max: 300_000_000,\n};\n\nexport function getTierSpeechLimit(tier?: string | null): number {\n  return TIER_SPEECH_LIMITS[normalizeTier(tier)];\n}\n\n// Limites de requêtes API hebdomadaires (remise à zéro le lundi 00:00 UTC)\nexport const TIER_REQUEST_LIMITS: Record = {\n  Free: 500,\n  Plus: 1500,\n  Pro: 3000,\n  Max: 7500,\n};\n\nexport function getTierRequestLimit(tier?: string | null): number {\n  return TIER_REQUEST_LIMITS[normalizeTier(tier)];\n}\n\n/**\n * Extrait le forfait (TIER_USER) encodé directement dans une clé API au format :\n * mai-TIER_USER-XXXXX-XXXXX (ex: mai-free-ABC12-defgh, mai-plus-..., mai-pro-..., mai-max-...)\n * Renvoie \"Free\", \"Plus\", \"Pro\", \"Max\" ou null si non présent.\n */\nexport function extractTierFromApiKey(\n  apiKey: string | null | undefined,\n): \"Free\" | \"Plus\" | \"Pro\" | \"Max\" | null {\n  if (!apiKey || typeof apiKey !== \"string\") return null;\n  const match = apiKey.trim().match(/^mai-(free|plus|pro|max)-/i);\n  if (!match) return null;\n  const t = match[1].toLowerCase();\n  if (t === \"free\") return \"Free\";\n  if (t === \"plus\") return \"Plus\";\n  if (t === \"pro\") return \"Pro\";\n  if (t === \"max\") return \"Max\";\n  return null;\n}\n\n/**\n * Calcule l'augmentation temporaire de quota active pour un utilisateur et un type de service.\n */\nexport async function getUserQuotaBoost(\n  sql: any,\n  userId: string | null | undefined,\n  quotaType: \"mai\" | \"api\" | \"images\" | \"audio\",\n): Promise {\n  if (!sql || !userId) return 0;\n  try {\n    const rows = await sql`\n      SELECT COALESCE(SUM(boost_amount), 0) as total_boost\n      FROM user_quota_boosts\n      WHERE (\n        user_id = 'all'\n        OR user_id = ${userId}::text\n        OR user_id IN (\n          SELECT id::text FROM users WHERE id::text = ${userId}::text OR email = ${userId}::text OR username = ${userId}::text\n        )\n        OR user_id IN (\n          SELECT email FROM users WHERE id::text = ${userId}::text OR email = ${userId}::text OR username = ${userId}::text\n        )\n        OR user_id IN (\n          SELECT username FROM users WHERE id::text = ${userId}::text OR email = ${userId}::text OR username = ${userId}::text\n        )\n      )\n        AND quota_type = ${quotaType}\n        AND is_active = TRUE\n        AND starts_at <= NOW()\n        AND expires_at >= NOW()\n    `;\n    return Number(rows[0]?.total_boost || 0);\n  } catch {\n    return 0;\n  }\n}\n\n// Limites quotidiennes de génération d'images\nexport const TIER_DAILY_IMAGE_LIMITS: Record = {\n  Free: 5,\n  Plus: 10,\n  Pro: 20,\n  Max: 35,\n};\n\nexport function getTierDailyImageLimit(tier?: string | null): number {\n  return TIER_DAILY_IMAGE_LIMITS[normalizeTier(tier)];\n}\n\n// Coût en requêtes API par image générée (multiplié par le nombre d'images demandées)\nexport const TIER_IMAGE_REQUEST_COST: Record = {\n  Free: 100,\n  Plus: 50,\n  Pro: 25,\n  Max: 10,\n};\n\nexport function getTierImageRequestCost(tier?: string | null): number {\n  return TIER_IMAGE_REQUEST_COST[normalizeTier(tier)];\n}\n\n// Limites de stockage Cloud par tier (en octets)\nconst GIB = 1024 * 1024 * 1024;\n\nexport const STORAGE_LIMITS_BYTES: Record = {\n  Free: 10 * GIB,\n  Plus: 20 * GIB,\n  Pro: 40 * GIB,\n  Max: 60 * GIB,\n};\n\nexport function getTierStorageLimitBytes(tier?: string | null): number {\n  return STORAGE_LIMITS_BYTES[normalizeTier(tier)];\n}\n\nexport function getDb() {\n  const url = Deno.env.get(\"DATABASE_URL\");\n  if (!url) {\n    throw new Error(\"DATABASE_URL not set\");\n  }\n  return neon(url);\n}\n\nexport function getJwtSecret(): Uint8Array {\n  const secret =\n    (typeof Deno !== \"undefined\"\n      ? Deno.env.get(\"MAI_JWT_SECRET\") || Deno.env.get(\"JWT_SECRET\")\n      : null) ||\n    \"mai_super_secret_jwt_key_2026_default_vibe\";\n  return new TextEncoder().encode(secret);\n}\n\n// ─────────────────────────────────────────────\n// Helpers d'authentification & Utilitaires\n// ─────────────────────────────────────────────\nexport async function signToken(\n  payload: Record,\n): Promise {\n  return new SignJWT(payload)\n    .setProtectedHeader({ alg: \"HS256\" })\n    .setIssuedAt()\n    .setExpirationTime(JWT_EXPIRY)\n    .sign(getJwtSecret());\n}\n\nexport async function verifyToken(\n  token: string,\n): Promise> {\n  // Vérif SQLite (legacy Val Town)\n  try {\n    const sqliteResult = await sqlite.execute({\n      args: [token],\n      sql: \"SELECT 1 FROM token_blacklist WHERE token = ?\",\n    });\n    if (sqliteResult && sqliteResult.rows && sqliteResult.rows.length > 0) {\n      throw new Error(\"Token révoqué.\");\n    }\n  } catch (e: any) {\n    if (e?.message === \"Token révoqué.\") throw e;\n  }\n\n  // Vérif Postgres token_blacklist avec TTL 14j\n  try {\n    const sql = getDb();\n    const pgResult =\n      await sql`SELECT 1 FROM token_blacklist WHERE token = ${token} LIMIT 1`;\n    if (pgResult && pgResult.length > 0) {\n      throw new Error(\"Token révoqué.\");\n    }\n  } catch (e: any) {\n    if (e?.message === \"Token révoqué.\") throw e;\n  }\n\n  const { payload } = await jwtVerify(token, getJwtSecret());\n  return payload as Record;\n}\n\nexport async function blacklistToken(token: string) {\n  const expiresAt = new Date(\n    Date.now() + 14 * 24 * 60 * 60 * 1000,\n  ).toISOString();\n  try {\n    await sqlite.execute({\n      args: [token],\n      sql: \"INSERT OR IGNORE INTO token_blacklist (token) VALUES (?)\",\n    });\n  } catch {}\n  try {\n    const sql = getDb();\n    await sql`INSERT INTO token_blacklist (token, revoked_at, expires_at) VALUES (${token}, NOW(), ${expiresAt}::timestamp) ON CONFLICT (token) DO NOTHING`;\n  } catch {}\n  // Nettoyage opportuniste des vieux tokens\n  try {\n    const sql = getDb();\n    await sql`DELETE FROM token_blacklist WHERE expires_at < NOW() OR revoked_at < NOW() - INTERVAL '14 days'`;\n  } catch {}\n  try {\n    await sqlite.execute({\n      sql:\n        \"DELETE FROM token_blacklist WHERE revoked_at < datetime('now', '-14 days')\",\n      args: [],\n    });\n  } catch {}\n}\n\nexport function extractToken(req: Request): string | null {\n  const auth = req.headers.get(\"Authorization\");\n  if (!auth?.startsWith(\"Bearer \")) {\n    return null;\n  }\n  return auth.slice(7);\n}\n\nexport function parseUserAgent(ua: string) {\n  const uaLower = ua.toLowerCase();\n  let os = \"linux\";\n  let osVersion = \"Linux\";\n\n  if (uaLower.includes(\"iphone\")) {\n    os = \"apple\";\n    osVersion = \"iPhone (iOS)\";\n  } else if (uaLower.includes(\"ipad\")) {\n    os = \"apple\";\n    osVersion = \"iPad (iPadOS)\";\n  } else if (uaLower.includes(\"mac os\") || uaLower.includes(\"macintosh\")) {\n    os = \"apple\";\n    osVersion = \"macOS\";\n  } else if (\n    uaLower.includes(\"windows nt 10.0\") ||\n    uaLower.includes(\"windows 11\") ||\n    uaLower.includes(\"windows 10\")\n  ) {\n    os = \"microsoft\";\n    osVersion = \"Windows 10/11\";\n  } else if (uaLower.includes(\"win\")) {\n    os = \"microsoft\";\n    osVersion = \"Windows\";\n  } else if (uaLower.includes(\"android\")) {\n    os = \"google\";\n    osVersion = \"Android\";\n  } else if (uaLower.includes(\"ubuntu\")) {\n    os = \"linux\";\n    osVersion = \"Ubuntu Linux\";\n  } else if (uaLower.includes(\"debian\")) {\n    os = \"linux\";\n    osVersion = \"Debian Linux\";\n  } else if (uaLower.includes(\"fedora\")) {\n    os = \"linux\";\n    osVersion = \"Fedora Linux\";\n  }\n\n  let model = \"Navigateur Web\";\n  let version = \"\";\n\n  if (uaLower.includes(\"mai-cli\") || uaLower.includes(\"mai cli\")) {\n    model = \"mAI CLI\";\n    version = \"Terminal\";\n  } else if (uaLower.includes(\"pulse-extension\") || uaLower.includes(\"pulse\")) {\n    model = \"Pulse Extension\";\n    version = \"Extension\";\n  } else if (uaLower.includes(\"edg/\")) {\n    model = \"Microsoft Edge\";\n    const match = ua.match(/Edg\\/([0-9.]+)/i);\n    if (match) {\n      version = `v${match[1].split(\".\")[0]}`;\n    }\n  } else if (uaLower.includes(\"opr/\") || uaLower.includes(\"opera/\")) {\n    model = \"Opera\";\n    const match = ua.match(/(?:OPR|Opera)\\/([0-9.]+)/i);\n    if (match) {\n      version = `v${match[1].split(\".\")[0]}`;\n    }\n  } else if (uaLower.includes(\"chrome/\")) {\n    model = \"Google Chrome\";\n    const match = ua.match(/Chrome\\/([0-9.]+)/i);\n    if (match) {\n      version = `v${match[1].split(\".\")[0]}`;\n    }\n  } else if (uaLower.includes(\"firefox/\")) {\n    model = \"Mozilla Firefox\";\n    const match = ua.match(/Firefox\\/([0-9.]+)/i);\n    if (match) {\n      version = `v${match[1].split(\".\")[0]}`;\n    }\n  } else if (uaLower.includes(\"safari/\") && !uaLower.includes(\"chrome\")) {\n    model = \"Apple Safari\";\n    const match = ua.match(/Version\\/([0-9.]+)/i);\n    if (match) {\n      version = `v${match[1].split(\".\")[0]}`;\n    }\n  }\n\n  const fullVersion = version ? `${osVersion} • ${version}` : osVersion;\n  const osLabel = os === \"apple\"\n    ? \"Apple\"\n    : os === \"microsoft\"\n    ? \"Windows\"\n    : os === \"google\"\n    ? \"Google\"\n    : \"Linux\";\n  const deviceName = `${model} (${osLabel})`;\n\n  return {\n    device_model: model,\n    device_name: deviceName,\n    device_version: fullVersion,\n    os,\n  };\n}\n\nexport function getWeekData() {\n  const now = new Date();\n  const day = now.getUTCDay() || 7;\n\n  const weekStart = new Date(now);\n  weekStart.setUTCDate(now.getUTCDate() - (day - 1));\n  weekStart.setUTCHours(0, 0, 0, 0);\n\n  const nextReset = new Date(weekStart);\n  nextReset.setUTCDate(weekStart.getUTCDate() + 7);\n\n  return {\n    nextResetIso: nextReset.toISOString(),\n    weekStartStr: weekStart.toISOString().split(\"T\")[0],\n  };\n}\n\n// ─────────────────────────────────────────────\n// E-mails & Vérification (SQLite)\n// ─────────────────────────────────────────────\nexport async function initSQLite() {\n  await sqlite.execute(`\n    CREATE TABLE IF NOT EXISTS verification_codes (\n      email TEXT,\n      code TEXT,\n      action TEXT,\n      expires_at DATETIME,\n      PRIMARY KEY (email, action)\n    );\n  `);\n  await sqlite.execute(`\n    CREATE TABLE IF NOT EXISTS token_blacklist (\n      token TEXT PRIMARY KEY,\n      revoked_at DATETIME DEFAULT CURRENT_TIMESTAMP\n    );\n  `);\n}\n\nexport async function generateVerificationCode(\n  email: string,\n  action: string,\n): Promise {\n  const isDeletion = action === \"delete_account\";\n  const length = isDeletion ? 8 : 6;\n  const min = 10 ** (length - 1);\n  const max = 10 ** length - 1;\n  // Crypto PRNG (corrige Math.random prévisible)\n  const range = max - min;\n  const randomValue = crypto.getRandomValues(new Uint32Array(1))[0] /\n    0xff_ff_ff_ff;\n  const code = Math.floor(min + randomValue * range)\n    .toString()\n    .padStart(length, \"0\");\n  const expiresAt = new Date(Date.now() + 10 * 60_000).toISOString(); // 10 minutes\n\n  await sqlite.execute({\n    args: [email, code, action, expiresAt],\n    sql:\n      \"INSERT OR REPLACE INTO verification_codes (email, code, action, expires_at) VALUES (?, ?, ?, ?)\",\n  });\n\n  return code;\n}\n\nexport async function verifyVerificationCode(\n  email: string,\n  code: string,\n  action: string,\n): Promise {\n  const result = await sqlite.execute({\n    args: [email, action],\n    sql:\n      \"SELECT code, expires_at FROM verification_codes WHERE email = ? AND action = ?\",\n  });\n\n  if (result.rows.length === 0) {\n    return false;\n  }\n\n  const storedCode = result.rows[0][0] as string;\n  const expiresAt = new Date(result.rows[0][1] as string);\n\n  if (expiresAt < new Date()) {\n    await sqlite.execute({\n      args: [email, action],\n      sql: \"DELETE FROM verification_codes WHERE email = ? AND action = ?\",\n    });\n    return false;\n  }\n\n  if (storedCode === code) {\n    await sqlite.execute({\n      args: [email, action],\n      sql: \"DELETE FROM verification_codes WHERE email = ? AND action = ?\",\n    });\n    return true;\n  }\n\n  return false;\n}\n\nexport { sqlite };",[168],"d2b2ab48-9008-4015-8343-21a5aa3e4587",316,["D",1789229716185],15,"import bcrypt from \"npm:bcryptjs\";\nimport type { Hono } from \"npm:hono@4\";\nimport {\n  BCRYPT_ROUNDS,\n  clientIp,\n  extractToken,\n  generateVerificationCode,\n  getDb,\n  parseUserAgent,\n  rateLimit,\n  signToken,\n  sqlite,\n  verifyToken,\n  verifyVerificationCode,\n} from \"./config.ts\";\nimport { sendVerificationEmail } from \"./email.ts\";\nimport { createRegisterMulti } from \"./vibe-common.ts\";\n\nexport function registerAuthRoutes(app: Hono) {\n  const registerMulti = createRegisterMulti(app);\n\n  // GET /register info endpoint (évite 404 lors des tests au navigateur)\n  registerMulti(\"get\", [\n    \"/register\",\n    \"/v1/register\",\n    \"/api/register\",\n    \"/api/vibe/register\",\n  ], (c) => {\n    return c.json({\n      service: \"mAI Vibe Auth\",\n      endpoint: \"/register\",\n      method: \"POST\",\n      description:\n        \"Pour créer un compte, envoyez une requête HTTP POST avec { email, username, password } en JSON.\",\n    });\n  });\n\n  // POST /register\n  registerMulti(\"post\", [\n    \"/register\",\n    \"/v1/register\",\n    \"/api/register\",\n    \"/api/vibe/register\",\n  ], async (c) => {\n    try {\n      // Anti-abus : 5 inscriptions / IP / 15 min\n      if (!rateLimit(`register:${clientIp(c)}`, 5, 15 * 60_000)) {\n        return c.json(\n          { error: \"Trop de tentatives. Réessayez plus tard.\" },\n          429,\n        );\n      }\n      const { email, username, password } = await c.req.json();\n      if (!email || !username || !password) {\n        return c.json({ error: \"Champs manquants.\" }, 400);\n      }\n\n      const cleanEmail = String(email).trim().toLowerCase();\n      const cleanUsername = String(username).trim().toLowerCase().replace(\n        /^@/,\n        \"\",\n      );\n      if (!/^[a-z0-9_]{2,30}$/.test(cleanUsername)) {\n        return c.json(\n          {\n            error:\n              \"Le nom d'utilisateur doit comporter entre 2 et 30 caractères (lettres minuscules, chiffres, _).\",\n          },\n          400,\n        );\n      }\n\n      const sql = getDb();\n      const existing =\n        await sql`SELECT id FROM users WHERE LOWER(email) = ${cleanEmail} OR LOWER(username) = ${cleanUsername} LIMIT 1`;\n      if (existing.length > 0) {\n        return c.json({ error: \"Email ou nom d'utilisateur déjà pris.\" }, 400);\n      }\n\n      const code = await generateVerificationCode(cleanEmail, \"register\");\n      await sendVerificationEmail(cleanEmail, code, \"register\");\n\n      return c.json({\n        email: cleanEmail,\n        status: \"verification_required\",\n        success: true,\n      });\n    } catch (err: any) {\n      console.error(\"Register Error:\", err);\n      return c.json({ error: err?.message || \"Erreur serveur.\" }, 500);\n    }\n  });\n\n  // POST /verify-register\n  registerMulti(\"post\", [\n    \"/verify-register\",\n    \"/v1/verify-register\",\n    \"/api/verify-register\",\n    \"/api/vibe/verify-register\",\n  ], async (c) => {\n    try {\n      const { email, username, password, code } = await c.req.json();\n      if (!email || !username || !password || !code) {\n        return c.json({ error: \"Champs manquants.\" }, 400);\n      }\n\n      const cleanEmail = String(email).trim().toLowerCase();\n      const cleanUsername = String(username).trim().toLowerCase().replace(\n        /^@/,\n        \"\",\n      );\n      if (!/^[a-z0-9_]{2,30}$/.test(cleanUsername)) {\n        return c.json(\n          {\n            error:\n              \"Le nom d'utilisateur doit comporter entre 2 et 30 caractères (lettres minuscules, chiffres, _).\",\n          },\n          400,\n        );\n      }\n\n      const isValid = await verifyVerificationCode(\n        cleanEmail,\n        code,\n        \"register\",\n      );\n      if (!isValid) {\n        return c.json({ error: \"Code invalide ou expiré.\" }, 400);\n      }\n\n      const sql = getDb();\n      const existing =\n        await sql`SELECT id FROM users WHERE LOWER(email) = ${cleanEmail} OR LOWER(username) = ${cleanUsername} LIMIT 1`;\n      if (existing.length > 0) {\n        return c.json({ error: \"Email ou nom d'utilisateur déjà pris.\" }, 400);\n      }\n\n      const hash = await bcrypt.hash(password, BCRYPT_ROUNDS);\n\n      const result = await sql`\n        INSERT INTO users (email, username, password_hash, tier)\n        VALUES (${cleanEmail}, ${cleanUsername}, ${hash}, 'Free')\n        RETURNING id, tier\n      `;\n\n      const user = result[0];\n      const token = await signToken({ sub: user.id, tier: user.tier });\n\n      const userAgent = c.req.header(\"user-agent\") || \"\";\n      const ip = c.req.header(\"cf-connecting-ip\") ||\n        c.req.header(\"x-forwarded-for\") ||\n        \"Inconnue\";\n      const { os, device_model, device_version, device_name } = parseUserAgent(\n        userAgent,\n      );\n\n      try {\n        await sql`\n          INSERT INTO connected_devices (user_id, token, os, device_model, device_version, ip_address, device_name)\n          VALUES (${user.id}::text, ${token}, ${os}, ${device_model}, ${device_version}, ${ip}, ${device_name})\n        `;\n      } catch (dbErr) {\n        console.error(\"Erreur insertion device:\", dbErr);\n      }\n\n      return c.json({ success: true, tier: user.tier, token });\n    } catch (err: any) {\n      console.error(\"Verify Register Error:\", err);\n      return c.json({ error: err?.message || \"Erreur serveur.\" }, 500);\n    }\n  });\n\n  // GET /login info endpoint (évite 404 lors des tests au navigateur)\n  registerMulti(\n    \"get\",\n    [\"/login\", \"/v1/login\", \"/api/login\", \"/api/vibe/login\"],\n    (c) => {\n      return c.json({\n        service: \"mAI Vibe Auth\",\n        endpoint: \"/login\",\n        method: \"POST\",\n        description:\n          \"Pour vous connecter, envoyez une requête HTTP POST avec { identifier, password } en JSON.\",\n      });\n    },\n  );\n\n  // POST /login\n  registerMulti(\"post\", [\n    \"/login\",\n    \"/v1/login\",\n    \"/api/login\",\n    \"/api/vibe/login\",\n  ], async (c) => {\n    let body;\n    try {\n      body = await c.req.json();\n    } catch (err: any) {\n      return c.json({\n        error:\n          \"Requête JSON invalide (vérifiez les guillemets double de votre payload).\",\n      }, 400);\n    }\n    try {\n      // Anti brute-force : 10 tentatives / IP / 5 min\n      if (!rateLimit(`login:${clientIp(c)}`, 10, 5 * 60_000)) {\n        return c.json(\n          { error: \"Trop de tentatives. Réessayez plus tard.\" },\n          429,\n        );\n      }\n      const { email, password, identifier } = body;\n      const loginId = (identifier || email || \"\").trim();\n      if (!loginId || !password) {\n        return c.json({ error: \"Champs manquants.\" }, 400);\n      }\n\n      const cleanId = loginId.toLowerCase();\n      const cleanUser = cleanId.replace(/^@/, \"\");\n\n      const sql = getDb();\n      const users = await sql`\n          SELECT id, email, username, password_hash, tier, is_blocked \n          FROM users \n          WHERE LOWER(email) = ${cleanId} \n             OR LOWER(username) = ${cleanUser} \n             OR phone = ${loginId} \n          LIMIT 1\n        `;\n      if (users.length === 0) {\n        return c.json({\n          error:\n            \"Aucun compte n'a été trouvé avec cet identifiant ou cet e-mail. Avez-vous créé votre compte ?\",\n          accountNotFound: true,\n        }, 401);\n      }\n\n      const user = users[0];\n      const match = await bcrypt.compare(password, user.password_hash);\n      if (!match) {\n        return c.json({\n          error:\n            \"Mot de passe incorrect pour ce compte. Veuillez vérifier votre saisie.\",\n          invalidPassword: true,\n        }, 401);\n      }\n\n      // Compte bloqué par un administrateur : refus explicite (403)\n      if (user.is_blocked) {\n        return c.json(\n          {\n            error:\n              \"Votre compte a été bloqué par un administrateur. Contactez le support pour demander sa réactivation.\",\n            blocked: true,\n          },\n          403,\n        );\n      }\n\n      // Paramètre administrateur : ce compte exige-t-il un code de vérification à chaque connexion ?\n      // (colonne users.require_login_verification — script SQL tmp/016_require_login_verification.sql ;\n      //  défaut TRUE si la colonne est absente ou NULL)\n      let requiresOtp = true;\n      try {\n        const flags = await sql`\n          SELECT COALESCE(require_login_verification, TRUE) AS flag\n          FROM users\n          WHERE id = ${user.id}\n          LIMIT 1\n        `;\n        requiresOtp = flags[0]?.flag !== false;\n      } catch {\n        // Colonne non migrée : comportement par défaut conservé (code exigé)\n      }\n\n      if (!requiresOtp) {\n        // Connexion directe sans code de vérification (paramètre désactivé par un administrateur)\n        const token = await signToken({ sub: user.id, tier: user.tier });\n        return c.json({ success: true, tier: user.tier, token });\n      }\n\n      const code = await generateVerificationCode(user.email, \"login\");\n      await sendVerificationEmail(user.email, code, \"login\");\n\n      return c.json({\n        email: user.email,\n        status: \"verification_required\",\n        success: true,\n      });\n    } catch (err: any) {\n      console.error(\"Login Error:\", err?.message || err, err?.stack);\n      return c.json({ error: err?.message || \"Erreur serveur.\" }, 500);\n    }\n  });\n\n  // POST /verify-login\n  registerMulti(\"post\", [\n    \"/verify-login\",\n    \"/v1/verify-login\",\n    \"/api/verify-login\",\n    \"/api/vibe/verify-login\",\n  ], async (c) => {\n    let body;\n    try {\n      body = await c.req.json();\n    } catch (err: any) {\n      return c.json({\n        error:\n          \"Requête JSON invalide (vérifiez les guillemets de votre payload).\",\n      }, 400);\n    }\n\n    try {\n      const { email, code, identifier } = body;\n      const loginId = (email || identifier || \"\").trim();\n      if (!loginId || !code) {\n        return c.json({ error: \"Champs manquants.\" }, 400);\n      }\n\n      const cleanId = loginId.toLowerCase();\n      const cleanUser = cleanId.replace(/^@/, \"\");\n\n      const sql = getDb();\n      const users = await sql`\n          SELECT id, tier, is_blocked, email, username \n          FROM users \n          WHERE LOWER(email) = ${cleanId} \n             OR LOWER(username) = ${cleanUser} \n          LIMIT 1\n        `;\n      if (users.length === 0) {\n        return c.json({ error: \"Utilisateur introuvable.\" }, 404);\n      }\n\n      const user = users[0];\n\n      const isValid = await verifyVerificationCode(user.email, code, \"login\");\n      if (!isValid) {\n        return c.json({ error: \"Code invalide ou expiré.\" }, 400);\n      }\n\n      // Compte bloqué par un administrateur : refus explicite (403)\n      if (user.is_blocked) {\n        return c.json(\n          {\n            error:\n              \"Votre compte a été bloqué par un administrateur. Contactez le support pour demander sa réactivation.\",\n            blocked: true,\n          },\n          403,\n        );\n      }\n\n      const token = await signToken({ sub: user.id, tier: user.tier });\n\n      const userAgent = c.req.header(\"user-agent\") || \"\";\n      // Pour les tests en dev, on utilise une IP par défaut\n      let ip = c.req.header(\"cf-connecting-ip\") ||\n        c.req.header(\"x-forwarded-for\") ||\n        c.req.header(\"x-real-ip\") ||\n        \"\";\n      if (!ip || ip === \"::1\" || ip === \"127.0.0.1\") {\n        ip = \"8.8.8.8\"; // IP Google par défaut pour ne pas planter l'API\n      } else {\n        // Extraire la première IP si on a une liste\n        ip = ip.split(\",\")[0].trim();\n      }\n      const { os, device_model, device_version, device_name } = parseUserAgent(\n        userAgent,\n      );\n\n      let locationStr = \"Lieu inconnu\";\n      let countryStr = \"Pays inconnu\";\n      try {\n        const controller = new AbortController();\n        const timeout = setTimeout(() => controller.abort(), 3000);\n        const geoRes = await fetch(`https://ip-api.com/json/${ip}`, {\n          headers: { \"User-Agent\": \"mAI/1.0\" },\n          signal: controller.signal,\n        });\n        clearTimeout(timeout);\n        if (geoRes.ok) {\n          const geoData = await geoRes.json();\n          if (geoData.status === \"success\") {\n            locationStr = `${geoData.city}, ${geoData.country}`;\n            countryStr = geoData.country;\n          }\n        }\n      } catch (e) {\n        console.error(\"Erreur de géolocalisation:\", e);\n      }\n\n      // Vérifier si c'est un nouvel appareil ou un nouveau pays\n      let isNewDeviceOrLocation = true;\n      try {\n        const pastDevices = await sql`\n          SELECT device_name, location FROM connected_devices \n          WHERE user_id = ${user.id}::text\n        `;\n        if (pastDevices.length > 0) {\n          // C'est pas sa toute première connexion\n          const knownDevice = pastDevices.some(\n            (d) => d.device_name === device_name,\n          );\n          const knownLocation = pastDevices.some(\n            (d) => d.location && d.location.includes(countryStr),\n          );\n          if (knownDevice && knownLocation) {\n            isNewDeviceOrLocation = false;\n          }\n        } else {\n          // Première connexion jamais (donc nouvelle par defaut, ou pas besoin d'alerte? on envoie quand meme)\n          isNewDeviceOrLocation = true;\n        }\n      } catch (e) {\n        console.error(e);\n      }\n\n      try {\n        await sql`\n          INSERT INTO connected_devices (user_id, token, os, device_model, device_version, ip_address, device_name, location)\n          VALUES (${user.id}::text, ${token}, ${os}, ${device_model}, ${device_version}, ${ip}, ${device_name}, ${locationStr})\n        `;\n      } catch (dbErr) {\n        console.error(\"Erreur insertion device:\", dbErr);\n      }\n\n      if (isNewDeviceOrLocation) {\n        // On n'attend pas l'envoi de l'email\n        sendVerificationEmail(email, \"\", \"new_login\", {\n          device: device_name,\n          location: locationStr,\n        }).catch(console.error);\n      }\n\n      return c.json({ success: true, tier: user.tier, token });\n    } catch (err: any) {\n      console.error(\"Verify Login Error:\", err);\n      return c.json({ error: err?.message || \"Erreur serveur.\" }, 500);\n    }\n  });\n\n  // POST /resend-code\n  registerMulti(\"post\", [\n    \"/resend-code\",\n    \"/v1/resend-code\",\n    \"/api/resend-code\",\n    \"/api/vibe/resend-code\",\n  ], async (c) => {\n    try {\n      const { email, action } = await c.req.json();\n      if (!email || !action) {\n        return c.json({ error: \"Champs manquants.\" }, 400);\n      }\n\n      // Vérifier le rate-limit (1 minute)\n      const result = await sqlite.execute({\n        args: [email, action],\n        sql:\n          \"SELECT expires_at FROM verification_codes WHERE email = ? AND action = ?\",\n      });\n\n      if (result.rows.length > 0) {\n        const expiresAt = new Date(result.rows[0][0] as string);\n        const now = new Date();\n        // Si la date d'expiration est > maintenant + 9 minutes, ça veut dire qu'il a été généré il y a moins d'1 minute.\n        const diffMinutes = (expiresAt.getTime() - now.getTime()) / 60_000;\n        if (diffMinutes > 9) {\n          return c.json(\n            { error: \"Veuillez patienter 1 minute avant de renvoyer un code.\" },\n            429,\n          );\n        }\n      }\n\n      const code = await generateVerificationCode(email, action);\n      await sendVerificationEmail(email, code, action);\n\n      return c.json({ success: true });\n    } catch (err: any) {\n      console.error(\"Resend Code Error:\", err);\n      return c.json({ error: err?.message || \"Erreur serveur.\" }, 500);\n    }\n  });\n\n  // POST /verify-code\n  app.post(\"/verify-code\", async (c) => {\n    try {\n      const token = extractToken(c.req.raw);\n      if (!token) {\n        return c.json({ error: \"Non authentifié.\" }, 401);\n      }\n\n      const payload = await verifyToken(token);\n      const userId = String(payload.sub);\n\n      const body = await c.req.json();\n      const rawCode = body?.code;\n      if (!rawCode) {\n        return c.json({ error: \"Code requis.\" }, 400);\n      }\n\n      const inputCode = String(rawCode).trim().toUpperCase();\n      const sql = getDb();\n\n      let newTier: string | null = null;\n      let dbCodeId: number | null = null;\n\n      // 1. Recherche dans la table subscription_codes de la base de données\n      try {\n        const codeRows = await sql`\n          SELECT id, code, tier, max_uses, uses_count, is_active, expires_at \n          FROM subscription_codes \n          WHERE UPPER(code) = UPPER(${inputCode}) \n          LIMIT 1\n        `;\n\n        if (codeRows.length > 0) {\n          const row = codeRows[0];\n\n          if (!row.is_active) {\n            return c.json(\n              { error: \"Ce code d'abonnement est désactivé.\" },\n              400,\n            );\n          }\n\n          if (row.expires_at && new Date(row.expires_at) < new Date()) {\n            return c.json({ error: \"Ce code d'abonnement a expiré.\" }, 400);\n          }\n\n          if (\n            row.max_uses > 0 &&\n            Number(row.uses_count) >= Number(row.max_uses)\n          ) {\n            return c.json(\n              { error: \"Ce code a atteint son quota maximal d'utilisations.\" },\n              400,\n            );\n          }\n\n          // Vérifier si l'utilisateur a déjà activé ce code spécifique\n          try {\n            const redemptions = await sql`\n              SELECT id FROM subscription_code_redemptions \n              WHERE code_id = ${row.id} AND user_id = ${userId}::text \n              LIMIT 1\n            `;\n            if (redemptions.length > 0) {\n              return c.json(\n                {\n                  error: \"Vous avez déjà débloqué votre forfait avec ce code.\",\n                },\n                400,\n              );\n            }\n          } catch (_redErr) {\n            // Ignorer si la table de redemptions n'est pas encore créée\n          }\n\n          newTier = row.tier;\n          dbCodeId = row.id;\n        }\n      } catch (dbErr) {\n        console.warn(\n          \"Table subscription_codes non accessible, vérification fallback ENV:\",\n          dbErr,\n        );\n      }\n\n      // 2. Fallback vers les variables d'environnement si non trouvé en base\n      if (!newTier) {\n        const upgradeCodes: Record = {};\n\n        const plusCode = Deno.env.get(\"MAI_PLUS_CODE\") ||\n          Deno.env.get(\"PLUS_CODE\");\n        if (plusCode) {\n          upgradeCodes[plusCode.trim().toUpperCase()] = \"Plus\";\n        }\n\n        const proCode = Deno.env.get(\"MAI_PRO_CODE\") ||\n          Deno.env.get(\"PRO_CODE\");\n        if (proCode) {\n          upgradeCodes[proCode.trim().toUpperCase()] = \"Pro\";\n        }\n\n        const maxCode = Deno.env.get(\"MAI_MAX_CODE\") ||\n          Deno.env.get(\"MAX_CODE\");\n        if (maxCode) {\n          upgradeCodes[maxCode.trim().toUpperCase()] = \"Max\";\n        }\n\n        newTier = upgradeCodes[inputCode] || null;\n      }\n\n      if (!newTier) {\n        console.log(`[Verify-Code] Code invalide soumis par user=${userId}`);\n        return c.json({ error: \"Code invalide ou expiré.\" }, 400);\n      }\n\n      // 3. Mise à jour de l'utilisateur et de ses clés API\n      await sql`UPDATE users SET tier = ${newTier} WHERE id::text = ${userId}::text`;\n      await sql`UPDATE mprojects_api_keys SET plan = ${newTier} WHERE user_id = ${userId}::text`;\n\n      // 4. Incrémentation du compteur et log de l'utilisation en base\n      if (dbCodeId) {\n        try {\n          await sql`\n            UPDATE subscription_codes \n            SET uses_count = uses_count + 1,\n                is_active = CASE WHEN max_uses > 0 AND (uses_count + 1) >= max_uses THEN FALSE ELSE is_active END\n            WHERE id = ${dbCodeId}\n          `;\n          await sql`\n            INSERT INTO subscription_code_redemptions (code_id, user_id)\n            VALUES (${dbCodeId}, ${userId}::text)\n          `;\n        } catch (updateErr) {\n          console.error(\"Erreur mise à jour usage code:\", updateErr);\n        }\n      }\n\n      // 5. Envoi d'un e-mail de remerciements pour la souscription\n      try {\n        const userRows =\n          await sql`SELECT email, username FROM users WHERE id::text = ${userId}::text LIMIT 1`;\n        if (userRows.length > 0 && userRows[0].email) {\n          await sendVerificationEmail(\n            userRows[0].email,\n            \"\",\n            \"subscription_unlocked\",\n            {\n              tier: newTier,\n              username: userRows[0].username,\n            },\n          );\n        }\n      } catch (mailErr) {\n        console.error(\n          \"Erreur envoi email remerciements souscription:\",\n          mailErr,\n        );\n      }\n\n      // 6. Nouveau token JWT avec le tier débloqué\n      const newToken = await signToken({ sub: userId, tier: newTier });\n\n      return c.json({\n        message: `Merci d'avoir souscrit au forfait ${newTier} !`,\n        success: true,\n        tier: newTier,\n        token: newToken,\n      });\n    } catch (err: any) {\n      console.error(\"Verify-Code error:\", err);\n      return c.json({ error: err?.message || \"Erreur serveur.\" }, 500);\n    }\n  });\n\n  // POST /update-profile\n  app.post(\"/update-profile\", async (c) => {\n    try {\n      const token = extractToken(c.req.raw);\n      if (!token) {\n        return c.json({ error: \"Non authentifié.\" }, 401);\n      }\n\n      const payload = await verifyToken(token);\n      const userId = payload.sub as string;\n\n      const body = await c.req.json();\n      const {\n        username,\n        email,\n        phone,\n        password,\n        currentPassword,\n        newsletter,\n        notify_limits,\n        auto_logout_minutes,\n      } = body;\n      const sql = getDb();\n\n      // Vérification obligatoire du mot de passe actuel\n      if (!currentPassword) {\n        return c.json(\n          {\n            error:\n              \"Le mot de passe actuel est obligatoire pour modifier vos informations.\",\n          },\n          400,\n        );\n      }\n\n      const currentUser =\n        await sql`SELECT email, password_hash FROM users WHERE id::text = ${userId}::text LIMIT 1`;\n      if (!currentUser || currentUser.length === 0) {\n        return c.json({ error: \"Utilisateur introuvable.\" }, 404);\n      }\n\n      const passMatch = await bcrypt.compare(\n        currentPassword,\n        currentUser[0].password_hash,\n      );\n      if (!passMatch) {\n        return c.json({ error: \"Le mot de passe actuel est incorrect.\" }, 400);\n      }\n\n      if (username && username.trim()) {\n        const cleanUsername = username.trim().toLowerCase().replace(/^@/, \"\");\n        if (!/^[a-z0-9_]{2,30}$/.test(cleanUsername)) {\n          return c.json(\n            {\n              error:\n                \"Le nom d'utilisateur doit comporter entre 2 et 30 caractères (lettres minuscules, chiffres, _).\",\n            },\n            400,\n          );\n        }\n        const existing =\n          await sql`SELECT id FROM users WHERE LOWER(username) = ${cleanUsername} AND id::text != ${userId}::text LIMIT 1`;\n        if (existing.length > 0) {\n          return c.json({\n            error: \"Ce nom d'utilisateur est déjà pris par un autre compte.\",\n          }, 400);\n        }\n        await sql`UPDATE users SET username = ${cleanUsername} WHERE id::text = ${userId}::text`;\n      }\n\n      if (email && email.trim()) {\n        const cleanEmail = email.trim();\n        const existing =\n          await sql`SELECT id FROM users WHERE email = ${cleanEmail} AND id::text != ${userId}::text LIMIT 1`;\n        if (existing.length > 0) {\n          return c.json(\n            { error: \"Cette adresse e-mail est déjà utilisée.\" },\n            400,\n          );\n        }\n        if (cleanEmail !== currentUser[0].email) {\n          // Send OTP instead of updating directly\n          const code = await generateVerificationCode(\n            cleanEmail,\n            \"verify_new_email\",\n          );\n          await sendVerificationEmail(cleanEmail, code, \"verify_new_email\");\n          return c.json({\n            email: cleanEmail,\n            status: \"email_verification_required\",\n            success: true,\n          });\n        }\n      }\n\n      if (phone !== undefined) {\n        const cleanPhone = phone ? phone.trim() : null;\n        if (cleanPhone) {\n          const existing =\n            await sql`SELECT id FROM users WHERE phone = ${cleanPhone} AND id::text != ${userId}::text LIMIT 1`;\n          if (existing.length > 0) {\n            return c.json(\n              {\n                error:\n                  \"Ce numéro de téléphone est déjà associé à un autre compte.\",\n              },\n              400,\n            );\n          }\n        }\n        await sql`UPDATE users SET phone = ${cleanPhone} WHERE id::text = ${userId}::text`;\n      }\n\n      if (newsletter !== undefined) {\n        await sql`UPDATE users SET newsletter = ${\n          Boolean(newsletter)\n        } WHERE id::text = ${userId}::text`;\n      }\n\n      if (notify_limits !== undefined) {\n        await sql`UPDATE users SET notify_limits = ${\n          Boolean(notify_limits)\n        } WHERE id::text = ${userId}::text`;\n      }\n\n      if (auto_logout_minutes !== undefined) {\n        const mins = Number.parseInt(auto_logout_minutes, 10);\n        if (!isNaN(mins)) {\n          await sql`UPDATE users SET auto_logout_minutes = ${mins} WHERE id::text = ${userId}::text`;\n        }\n      }\n\n      if (password && password.trim()) {\n        if (password.length < 6) {\n          return c.json(\n            { error: \"Le mot de passe doit contenir au moins 6 caractères.\" },\n            400,\n          );\n        }\n        const hash = await bcrypt.hash(password, BCRYPT_ROUNDS);\n        await sql`UPDATE users SET password_hash = ${hash} WHERE id::text = ${userId}::text`;\n      }\n\n      const updatedUser =\n        await sql`SELECT username, email, phone, tier, newsletter, notify_limits FROM users WHERE id::text = ${userId}::text LIMIT 1`;\n      const user = updatedUser[0];\n\n      return c.json({\n        email: user?.email,\n        newsletter: user?.newsletter,\n        notify_limits: user?.notify_limits,\n        phone: user?.phone,\n        success: true,\n        tier: user?.tier,\n        username: user?.username,\n      });\n    } catch {\n      return c.json({ error: \"Erreur lors de la mise à jour du profil.\" }, 500);\n    }\n  });\n\n  // POST /verify-new-email\n  app.post(\"/verify-new-email\", async (c) => {\n    try {\n      const token = extractToken(c.req.raw);\n      if (!token) {\n        return c.json({ error: \"Non authentifié.\" }, 401);\n      }\n      const payload = await verifyToken(token);\n      const userId = payload.sub as string;\n\n      const { email, code } = await c.req.json();\n      if (!email || !code) {\n        return c.json({ error: \"Champs manquants.\" }, 400);\n      }\n\n      const isValid = await verifyVerificationCode(\n        email,\n        code,\n        \"verify_new_email\",\n      );\n      if (!isValid) {\n        return c.json({ error: \"Code invalide ou expiré.\" }, 400);\n      }\n\n      const sql = getDb();\n      await sql`UPDATE users SET email = ${email.trim()} WHERE id::text = ${userId}::text`;\n\n      return c.json({ email: email.trim(), success: true });\n    } catch (err: any) {\n      console.error(\"verify-new-email Error:\", err);\n      return c.json({ error: err?.message || \"Erreur serveur.\" }, 500);\n    }\n  });\n\n  // POST /request-delete-account\n  app.post(\"/request-delete-account\", async (c) => {\n    try {\n      const token = extractToken(c.req.raw);\n      if (!token) {\n        return c.json({ error: \"Non authentifié.\" }, 401);\n      }\n      const payload = await verifyToken(token);\n      const userId = payload.sub as string;\n\n      const sql = getDb();\n      const currentUser =\n        await sql`SELECT email FROM users WHERE id::text = ${userId}::text LIMIT 1`;\n      if (!currentUser || currentUser.length === 0) {\n        return c.json({ error: \"Utilisateur introuvable.\" }, 404);\n      }\n\n      const email = currentUser[0].email;\n      const code = await generateVerificationCode(email, \"delete_account\");\n      await sendVerificationEmail(email, code, \"delete_account\");\n\n      return c.json({ email, success: true });\n    } catch (err: any) {\n      console.error(\"request-delete-account Error:\", err);\n      return c.json({ error: err?.message || \"Erreur serveur.\" }, 500);\n    }\n  });\n\n  // POST /confirm-delete-account\n  app.post(\"/confirm-delete-account\", async (c) => {\n    try {\n      const token = extractToken(c.req.raw);\n      if (!token) {\n        return c.json({ error: \"Non authentifié.\" }, 401);\n      }\n      const payload = await verifyToken(token);\n      const userId = payload.sub as string;\n\n      const { password, code, confirmationText } = await c.req.json();\n      if (!password || !code || confirmationText !== \"SUPPRIMER LE COMPTE\") {\n        return c.json(\n          { error: \"Informations de confirmation invalides.\" },\n          400,\n        );\n      }\n\n      const sql = getDb();\n      const currentUser =\n        await sql`SELECT email, password_hash FROM users WHERE id::text = ${userId}::text LIMIT 1`;\n      if (!currentUser || currentUser.length === 0) {\n        return c.json({ error: \"Utilisateur introuvable.\" }, 404);\n      }\n\n      const passMatch = await bcrypt.compare(\n        password,\n        currentUser[0].password_hash,\n      );\n      if (!passMatch) {\n        return c.json({ error: \"Mot de passe incorrect.\" }, 400);\n      }\n\n      const email = currentUser[0].email;\n      const isValid = await verifyVerificationCode(\n        email,\n        code,\n        \"delete_account\",\n      );\n      if (!isValid) {\n        return c.json({ error: \"Code invalide ou expiré.\" }, 400);\n      }\n\n      // Suppression (ou anonymisation)\n      await sql`DELETE FROM users WHERE id::text = ${userId}::text`;\n\n      // Révoquer le token pour déconnecter immédiatement\n      await sqlite.execute({\n        args: [token],\n        sql: \"INSERT OR IGNORE INTO token_blacklist (token) VALUES (?)\",\n      });\n\n      return c.json({ success: true });\n    } catch (err: any) {\n      console.error(\"confirm-delete-account Error:\", err);\n      return c.json({ error: err?.message || \"Erreur serveur.\" }, 500);\n    }\n  });\n\n  // GET /api-keys\n  app.get(\"/api-keys\", async (c) => {\n    try {\n      const token = extractToken(c.req.raw);\n      let userId = c.get(\"userId\");\n\n      if (token) {\n        try {\n          const payload = await verifyToken(token);\n          userId = (payload.sub as string) || userId;\n        } catch {}\n      }\n\n      const sql = getDb();\n\n      // Résolution du user_id réel via mprojects_api_keys si clé API transmise\n      if (token) {\n        try {\n          const keyRows = await sql`\n            SELECT k.user_id, u.tier, u.email, u.username\n            FROM mprojects_api_keys k\n            LEFT JOIN users u ON k.user_id = u.id::text OR k.user_id = u.username OR k.user_id = u.email\n            WHERE k.api_key = ${token}::text\n            LIMIT 1\n          `;\n          if (keyRows.length > 0) {\n            userId = keyRows[0].user_id;\n          }\n        } catch {}\n      }\n\n      if (!userId) {\n        return c.json({ error: \"Non authentifié.\" }, 401);\n      }\n\n      const [uRows, keyRows] = await Promise.all([\n        sql`SELECT tier FROM users WHERE id::text = ${userId}::text OR username = ${userId}::text OR email = ${userId}::text LIMIT 1`,\n        sql`\n          SELECT k.*, u.tier as user_tier\n          FROM mprojects_api_keys k\n          LEFT JOIN users u ON k.user_id = u.id::text OR k.user_id = u.username OR k.user_id = u.email\n          WHERE (\n            k.user_id = ${userId}::text \n            OR k.user_id IN (SELECT id::text FROM users WHERE id::text = ${userId}::text OR email = ${userId}::text OR username = ${userId}::text)\n            OR k.user_id IN (SELECT email FROM users WHERE id::text = ${userId}::text OR email = ${userId}::text OR username = ${userId}::text)\n            OR k.user_id IN (SELECT username FROM users WHERE id::text = ${userId}::text OR email = ${userId}::text OR username = ${userId}::text)\n          )\n          ORDER BY k.created_at DESC\n        `.catch(() => []),\n      ]);\n\n      const userTier = uRows[0]?.tier || \"Free\";\n      const validTiers = [\"free\", \"plus\", \"pro\", \"max\"];\n\n      const keys = keyRows.map((k: any) => {\n        const rawPlan = String(k.plan || \"\").trim();\n        const planLower = rawPlan.toLowerCase();\n        const isPlanTier = validTiers.includes(planLower);\n\n        // Nom personnalisé de la clé\n        const keyName = k.name || (isPlanTier ? `Clé ${rawPlan}` : rawPlan) ||\n          \"Clé API Principale\";\n        // Le forfait est strictement le forfait d'abonnement du compte (free, plus, pro, max)\n        const effectivePlan = k.user_tier || userTier ||\n          (isPlanTier ? rawPlan : \"Plus\");\n\n        return {\n          api_key: k.api_key,\n          name: keyName,\n          plan: effectivePlan,\n          request_count: Number(k.request_count || 0),\n          created_at: k.created_at,\n          last_used_at: k.last_used_at,\n        };\n      });\n\n      return c.json({ keys, success: true });\n    } catch (err: any) {\n      console.error(\"Erreur API Keys:\", err);\n      return c.json({ error: err?.message || \"Erreur serveur.\" }, 500);\n    }\n  });\n}",[185],"f772927d-accc-44e0-ab51-6c94d37d47fb",269,["D",1788800899725],"import type { Hono } from \"npm:hono@4\";\nimport {\n  extractTierFromApiKey,\n  extractToken,\n  getDb,\n  getTierSpeechLimit,\n  getUserQuotaBoost,\n  getWeekData,\n  verifyToken,\n} from \"./config.ts\";\n\nexport interface SpeechModelItem {\n  created: number;\n  description: string;\n  id: string;\n  name: string;\n  voices?: string[];\n}\n\nfunction cleanModelName(name: string): string {\n  return (name || \"\")\n    .replace(/\\s*\\((free|gratuit|free tier)\\)/gi, \"\")\n    .replace(/:free/gi, \"\")\n    .trim();\n}\n\nfunction getOpenRouterApiKey(userCustomKey?: string | null): string {\n  if (userCustomKey && userCustomKey.trim().startsWith(\"sk-or-\")) {\n    return userCustomKey.trim();\n  }\n  if (typeof Deno !== \"undefined\" && Deno.env) {\n    return Deno.env.get(\"OPENROUTER_API_KEY\") || \"\";\n  }\n  if (typeof process !== \"undefined\" && process.env) {\n    return process.env.OPENROUTER_API_KEY || \"\";\n  }\n  return \"\";\n}\n\n/**\n * Modèles Speech de repli avec voix disponibles et noms nettoyés sans (Free)\n */\nconst FALLBACK_SPEECH_MODELS = [\n  {\n    architecture: {\n      input_modalities: [\"text\"],\n      modality: \"text->speech\",\n      output_modalities: [\"speech\"],\n    },\n    created: Math.floor(Date.now() / 1000) - 86_400 * 30,\n    description:\n      \"Modèle Text-to-Speech (TTS) ultra-rapide et haute fidélité par Deepgram.\",\n    id: \"deepgram/flux-tts:free\",\n    name: \"Deepgram: Flux TTS\",\n    object: \"model\",\n    owned_by: \"deepgram\",\n    supported_parameters: [\"voice\", \"speed\", \"response_format\"],\n    voices: [\n      \"flux-alexis-en\",\n      \"flux-michael-en\",\n      \"flux-stacy-en\",\n      \"flux-sam-en\",\n      \"flux-asteria-en\",\n      \"flux-orion-en\",\n    ],\n  },\n];\n\nlet speechTablesInitialized = false;\nasync function ensureSpeechTables(sql: any) {\n  if (speechTablesInitialized) return;\n  try {\n    await sql`\n      CREATE TABLE IF NOT EXISTS weekly_speech_usage (\n        id SERIAL PRIMARY KEY,\n        user_id TEXT NOT NULL,\n        week_start DATE NOT NULL,\n        tokens_used BIGINT NOT NULL DEFAULT 0,\n        requests_count INTEGER NOT NULL DEFAULT 0,\n        updated_at TIMESTAMP NOT NULL DEFAULT NOW(),\n        CONSTRAINT weekly_speech_usage_user_week_unique UNIQUE (user_id, week_start)\n      )\n    `;\n    await sql`\n      CREATE TABLE IF NOT EXISTS mprojects_speech_generations (\n        id UUID PRIMARY KEY DEFAULT gen_random_uuid(),\n        user_id TEXT NOT NULL,\n        api_key TEXT,\n        model TEXT NOT NULL DEFAULT 'deepgram/flux-tts:free',\n        voice TEXT DEFAULT 'flux-alexis-en',\n        input_text TEXT NOT NULL,\n        audio_url TEXT,\n        tokens_count INTEGER NOT NULL DEFAULT 0,\n        character_count INTEGER NOT NULL DEFAULT 0,\n        status TEXT NOT NULL DEFAULT 'completed',\n        created_at TIMESTAMP NOT NULL DEFAULT NOW()\n      )\n    `;\n    await sql`ALTER TABLE mprojects_speech_generations ADD COLUMN IF NOT EXISTS audio_url TEXT`;\n    speechTablesInitialized = true;\n  } catch (err) {\n    console.error(\"[Speech API] Error initializing speech tables:\", err);\n  }\n}\n\nexport function registerAudioRoutes(app: Hono) {\n  try {\n    ensureSpeechTables(getDb()).catch(() => {});\n  } catch {}\n  // ─────────────────────────────────────────────\n  // GET /v1/models/speech, /models/speech & /v1/audio/models\n  // ─────────────────────────────────────────────\n  const handleGetSpeechModels = async (c: any) => {\n    try {\n      const res = await fetch(\n        \"https://openrouter.ai/api/v1/models?output_modalities=speech\",\n      );\n\n      let rawModels: any[] = [];\n      if (res.ok) {\n        const json = await res.json();\n        rawModels = json.data || [];\n      }\n\n      if (rawModels.length === 0) {\n        rawModels = FALLBACK_SPEECH_MODELS;\n      }\n\n      // Règle stricte : filtrer par l'ID contenant ':free' quel que soit le forfait\n      const freeSpeechModels = rawModels\n        .filter((m) =>\n          m && m.id && (m.id || \"\").toLowerCase().includes(\":free\")\n        )\n        .map((m) => {\n          const rawName = m.name || m.id;\n          const cleanedName = cleanModelName(rawName) || cleanModelName(m.id);\n          return {\n            architecture: m.architecture || {\n              input_modalities: [\"text\"],\n              modality: \"text->speech\",\n              output_modalities: [\"speech\"],\n            },\n            created: m.created || Math.floor(Date.now() / 1000),\n            description: m.description ||\n              `Modèle de synthèse vocale (TTS) ${cleanedName}.`,\n            id: m.id,\n            name: cleanedName,\n            object: \"model\",\n            owned_by: (m.id || \"\").split(\"/\")[0] || \"openrouter\",\n            supported_parameters: m.supported_parameters || [\n              \"voice\",\n              \"speed\",\n              \"response_format\",\n            ],\n            voices: m.voices || [\n              \"flux-alexis-en\",\n              \"flux-michael-en\",\n              \"flux-stacy-en\",\n              \"flux-sam-en\",\n              \"flux-asteria-en\",\n              \"flux-orion-en\",\n            ],\n          };\n        });\n\n      const finalModels = freeSpeechModels.length > 0\n        ? freeSpeechModels\n        : FALLBACK_SPEECH_MODELS;\n\n      return c.json({ data: finalModels, object: \"list\" });\n    } catch {\n      return c.json({ data: FALLBACK_SPEECH_MODELS, object: \"list\" });\n    }\n  };\n\n  app.get(\"/v1/models/speech\", handleGetSpeechModels);\n  app.get(\"/models/speech\", handleGetSpeechModels);\n  app.get(\"/v1/speech/models\", handleGetSpeechModels);\n  app.get(\"/speech/models\", handleGetSpeechModels);\n  app.get(\"/v1/audio/models\", handleGetSpeechModels);\n  app.get(\"/audio/models\", handleGetSpeechModels);\n\n  // ─────────────────────────────────────────────\n  // GET /v1/speech/voices & /v1/audio/voices\n  // ─────────────────────────────────────────────\n  const handleGetSpeechVoices = (c: any) => {\n    return c.json({\n      data: [\n        {\n          description: \"Voix féminine chaleureuse, naturelle et claire.\",\n          gender: \"female\",\n          id: \"flux-alexis-en\",\n          language: \"fr/en\",\n          name: \"Alexis\",\n        },\n        {\n          description: \"Voix masculine posée, fluide et professionnelle.\",\n          gender: \"male\",\n          id: \"flux-michael-en\",\n          language: \"fr/en\",\n          name: \"Michael\",\n        },\n        {\n          description: \"Voix féminine expressive, vive et dynamique.\",\n          gender: \"female\",\n          id: \"flux-stacy-en\",\n          language: \"fr/en\",\n          name: \"Stacy\",\n        },\n        {\n          description:\n            \"Voix masculine profonde, idéale pour narration & podcast.\",\n          gender: \"male\",\n          id: \"flux-sam-en\",\n          language: \"fr/en\",\n          name: \"Sam\",\n        },\n        {\n          description: \"Voix féminine moderne, douce et mélodieuse.\",\n          gender: \"female\",\n          id: \"flux-asteria-en\",\n          language: \"fr/en\",\n          name: \"Asteria\",\n        },\n        {\n          description: \"Voix masculine cinématique, intense et charismatique.\",\n          gender: \"male\",\n          id: \"flux-orion-en\",\n          language: \"fr/en\",\n          name: \"Orion\",\n        },\n      ],\n      object: \"list\",\n    });\n  };\n\n  app.get(\"/v1/speech/voices\", handleGetSpeechVoices);\n  app.get(\"/speech/voices\", handleGetSpeechVoices);\n  app.get(\"/v1/audio/voices\", handleGetSpeechVoices);\n  app.get(\"/audio/voices\", handleGetSpeechVoices);\n  app.get(\"/api/vibe/speech/voices\", handleGetSpeechVoices);\n  app.get(\"/vibe/speech/voices\", handleGetSpeechVoices);\n  app.get(\"/api/speech/voices\", handleGetSpeechVoices);\n  app.get(\"/api/v1/speech/voices\", handleGetSpeechVoices);\n\n  // ─────────────────────────────────────────────\n  // GET /v1/speech/usage, /speech/usage, /v1/audio/usage & /usage/speech\n  // ─────────────────────────────────────────────\n  const handleGetSpeechUsage = async (c: any) => {\n    try {\n      const token = extractToken(c.req.raw);\n      let userId = c.get(\"userId\");\n      let userPlan = c.get(\"userPlan\") || \"Free\";\n\n      if (token) {\n        try {\n          const payload = await verifyToken(token);\n          userId = (payload.sub as string) || userId;\n          userPlan = (payload.tier as string) || userPlan;\n        } catch {}\n      }\n\n      const sql = getDb();\n\n      // Résolution du user_id réel via mprojects_api_keys si token ou userId transmis\n      if (token) {\n        try {\n          const keyRows = await sql`\n            SELECT k.user_id, u.tier, u.email, u.username\n            FROM mprojects_api_keys k\n            LEFT JOIN users u ON k.user_id = u.id::text OR k.user_id = u.username OR k.user_id = u.email\n            WHERE k.api_key = ${token}::text\n            LIMIT 1\n          `;\n          if (keyRows.length > 0) {\n            userId = keyRows[0].user_id;\n            userPlan = keyRows[0].tier || userPlan;\n          }\n        } catch {}\n      }\n\n      if (!userId) {\n        return c.json({ error: \"Non authentifié.\" }, 401);\n      }\n\n      const { weekStartStr, nextResetIso } = getWeekData();\n\n      const [uRows, usageRows] = await Promise.all([\n        sql`SELECT id, email, username, tier FROM users WHERE id::text = ${userId}::text OR username = ${userId}::text OR email = ${userId}::text LIMIT 1`,\n        sql`\n          SELECT COALESCE(SUM(tokens_used::numeric), 0) as tokens_used, COALESCE(SUM(requests_count::numeric), 0) as requests_count \n          FROM weekly_speech_usage \n          WHERE (\n            user_id = ${userId}::text \n            OR user_id IN (SELECT id::text FROM users WHERE id::text = ${userId}::text OR email = ${userId}::text OR username = ${userId}::text)\n            OR user_id IN (SELECT email FROM users WHERE id::text = ${userId}::text OR email = ${userId}::text OR username = ${userId}::text)\n            OR user_id IN (SELECT username FROM users WHERE id::text = ${userId}::text OR email = ${userId}::text OR username = ${userId}::text)\n          ) AND week_start = ${weekStartStr}::date\n        `.catch(() => []),\n      ]);\n\n      const keyTier = extractTierFromApiKey(token);\n      const effectiveTier = keyTier || uRows[0]?.tier || userPlan || \"Free\";\n      const tokensUsed = Number(usageRows[0]?.tokens_used || 0);\n      const requestsCount = Number(usageRows[0]?.requests_count || 0);\n      const audioBoost = await getUserQuotaBoost(sql, userId, \"audio\");\n      const weeklyLimit = getTierSpeechLimit(effectiveTier) + audioBoost;\n\n      return c.json({\n        plan: effectiveTier,\n        requestsCount,\n        resetAt: nextResetIso,\n        tokensUsed,\n        userId,\n        weekStart: weekStartStr,\n        weeklyLimit,\n      });\n    } catch (err: any) {\n      return c.json(\n        {\n          details: err.message,\n          error: \"Erreur lors de la récupération de l'usage Speech.\",\n        },\n        500,\n      );\n    }\n  };\n\n  app.get(\"/v1/audio/usage\", handleGetSpeechUsage);\n  app.get(\"/v1/speech/usage\", handleGetSpeechUsage);\n  app.get(\"/audio/usage\", handleGetSpeechUsage);\n  app.get(\"/speech/usage\", handleGetSpeechUsage);\n  app.get(\"/usage/speech\", handleGetSpeechUsage);\n\n  // ─────────────────────────────────────────────\n  // GET /v1/audio/history & /v1/speech/history\n  // ─────────────────────────────────────────────\n  const handleGetSpeechHistory = async (c: any) => {\n    try {\n      const token = extractToken(c.req.raw);\n      let userId = c.get(\"userId\");\n\n      if (token) {\n        try {\n          const payload = await verifyToken(token);\n          userId = payload.sub as string;\n        } catch {}\n      }\n\n      if (!userId) {\n        return c.json({ error: \"Non authentifié.\" }, 401);\n      }\n\n      const sql = getDb();\n      const history = await sql`\n        SELECT id, title, pinned, model, voice, input_text, audio_url, tokens_count, character_count, status, created_at\n        FROM mprojects_speech_generations\n        WHERE user_id = ${userId}::text\n        ORDER BY pinned DESC, created_at DESC\n        LIMIT 50\n      `.catch(() => []);\n\n      const formattedHistory = history.map((item: any) => ({\n        ...item,\n        pinned: Boolean(item.pinned),\n        title: item.title || null,\n      }));\n\n      return c.json({ data: formattedHistory, success: true });\n    } catch (err: any) {\n      return c.json(\n        { details: err.message, error: \"Erreur historique audio.\" },\n        500,\n      );\n    }\n  };\n\n  const handleUpdateSpeechHistory = async (c: any) => {\n    try {\n      const token = extractToken(c.req.raw);\n      let userId = c.get(\"userId\");\n\n      if (token) {\n        try {\n          const payload = await verifyToken(token);\n          userId = payload.sub as string;\n        } catch {}\n      }\n\n      if (!userId) {\n        return c.json({ error: \"Non authentifié.\" }, 401);\n      }\n\n      const id = c.req.param(\"id\") || c.req.query(\"id\");\n      if (!id) {\n        return c.json({ error: \"ID manquant.\" }, 400);\n      }\n\n      const body = await c.req.json().catch(() => ({}));\n      const sql = getDb();\n      const sets: string[] = [];\n      const values: any[] = [];\n      let idx = 1;\n\n      if (body.title !== undefined) {\n        sets.push(`title = $${idx++}`);\n        values.push(\n          body.title ? String(body.title).trim().slice(0, 200) : null,\n        );\n      }\n      if (body.pinned !== undefined) {\n        sets.push(`pinned = $${idx++}`);\n        values.push(Boolean(body.pinned));\n      }\n\n      if (sets.length === 0) {\n        return c.json({ success: true });\n      }\n\n      values.push(id, userId);\n      const query = `UPDATE mprojects_speech_generations SET ${\n        sets.join(\", \")\n      } WHERE id::text = $${idx++}::text AND user_id = $${idx}::text RETURNING id, title, pinned`;\n      const result = await sql.unsafe(query, values);\n\n      return c.json({ data: result[0] || null, success: true });\n    } catch (err: any) {\n      return c.json(\n        { details: err.message, error: \"Erreur mise à jour audio.\" },\n        500,\n      );\n    }\n  };\n\n  app.get(\"/v1/audio/history\", handleGetSpeechHistory);\n  app.get(\"/v1/speech/history\", handleGetSpeechHistory);\n  app.get(\"/audio/history\", handleGetSpeechHistory);\n  app.get(\"/speech/history\", handleGetSpeechHistory);\n  app.patch(\"/v1/audio/history/:id\", handleUpdateSpeechHistory);\n  app.patch(\"/v1/audio/history\", handleUpdateSpeechHistory);\n  app.patch(\"/v1/speech/history/:id\", handleUpdateSpeechHistory);\n  app.patch(\"/v1/speech/history\", handleUpdateSpeechHistory);\n  app.patch(\"/audio/history/:id\", handleUpdateSpeechHistory);\n  app.patch(\"/audio/history\", handleUpdateSpeechHistory);\n  app.patch(\"/speech/history/:id\", handleUpdateSpeechHistory);\n  app.patch(\"/speech/history\", handleUpdateSpeechHistory);\n\n  // ─────────────────────────────────────────────\n  // DELETE /v1/audio/history/:id & /v1/speech/history/:id\n  // ─────────────────────────────────────────────\n  const handleDeleteSpeechHistory = async (c: any) => {\n    try {\n      const token = extractToken(c.req.raw);\n      let userId = c.get(\"userId\");\n\n      if (token) {\n        try {\n          const payload = await verifyToken(token);\n          userId = payload.sub as string;\n        } catch {}\n      }\n\n      if (!userId) {\n        return c.json({ error: \"Non authentifié.\" }, 401);\n      }\n\n      const id = c.req.param(\"id\") || c.req.query(\"id\");\n      if (!id) {\n        return c.json({ error: \"ID manquant.\" }, 400);\n      }\n\n      const sql = getDb();\n      await sql`\n        DELETE FROM mprojects_speech_generations\n        WHERE id::text = ${id}::text AND user_id = ${userId}::text\n      `;\n\n      return c.json({ message: \"Audio supprimé avec succès\", success: true });\n    } catch (err: any) {\n      return c.json(\n        { details: err.message, error: \"Erreur suppression audio.\" },\n        500,\n      );\n    }\n  };\n\n  app.delete(\"/v1/audio/history/:id\", handleDeleteSpeechHistory);\n  app.delete(\"/v1/audio/history\", handleDeleteSpeechHistory);\n  app.delete(\"/v1/speech/history/:id\", handleDeleteSpeechHistory);\n  app.delete(\"/v1/speech/history\", handleDeleteSpeechHistory);\n  app.delete(\"/audio/history/:id\", handleDeleteSpeechHistory);\n  app.delete(\"/audio/history\", handleDeleteSpeechHistory);\n\n  // ─────────────────────────────────────────────\n  // POST /v1/speech, /v1/audio/speech, /v1beta/models/*:synthesizeSpeech (OpenAI, Google & Anthropic SDK)\n  // ─────────────────────────────────────────────\n  const OPENAI_VOICE_MAP: Record = {\n    alloy: \"flux-alexis-en\",\n    echo: \"flux-michael-en\",\n    fable: \"flux-orion-en\",\n    nova: \"flux-stacy-en\",\n    onyx: \"flux-sam-en\",\n    shimmer: \"flux-asteria-en\",\n  };\n\n  const handleAudioSpeech = async (c: any) => {\n    try {\n      const token = extractToken(c.req.raw);\n      const authHeader = c.req.header(\"Authorization\");\n      const headerApiKey = c.req.header(\"x-api-key\") ||\n        c.req.header(\"X-API-Key\") ||\n        c.req.header(\"x-goog-api-key\") ||\n        c.req.header(\"X-Goog-Api-Key\");\n      const apiKey = authHeader?.startsWith(\"Bearer \")\n        ? authHeader.slice(7)\n        : headerApiKey || null;\n\n      let userId = c.get(\"userId\");\n      let userPlan = c.get(\"userPlan\") || \"Free\";\n\n      if (token) {\n        try {\n          const payload = await verifyToken(token);\n          userId = (payload.sub as string) || userId;\n          userPlan = (payload.tier as string) || userPlan;\n        } catch {}\n      }\n\n      if (!userId) {\n        return c.json(\n          { error: \"Non authentifié. Clé API ou token Bearer requis.\" },\n          401,\n        );\n      }\n\n      const body = await c.req.json().catch(() => ({}));\n      const reqPath = c.req.path || \"\";\n      const isGoogleTts = reqPath.includes(\":synthesizeSpeech\") ||\n        reqPath.includes(\":synthesize\") ||\n        Boolean(body.audioConfig);\n\n      // Extraction du texte / prompt (support OpenAI, Anthropic et Google Cloud TTS / Gemini)\n      const rawInput =\n        (typeof body.input === \"object\" ? body.input?.text : body.input) ||\n        body.text ||\n        body.prompt ||\n        \"\";\n      const input = typeof rawInput === \"string\" ? rawInput.trim() : \"\";\n\n      // Extraction du modèle demandé\n      const pathModel = reqPath\n        .replace(/^\\/(v1beta|v1)\\/models\\//, \"\")\n        .replace(/:(synthesizeSpeech|synthesize).*$/, \"\");\n      const requestedModel = body.model || pathModel ||\n        \"deepgram/flux-tts:free\";\n\n      // Mapping automatique des modèles OpenAI standards (tts-1, tts-1-hd) vers deepgram/flux-tts:free\n      let model = requestedModel;\n      if (\n        model === \"tts-1\" ||\n        model === \"tts-1-hd\" ||\n        model === \"speech\" ||\n        model.toLowerCase().includes(\"gemini\")\n      ) {\n        model = \"deepgram/flux-tts:free\";\n      }\n\n      // Extraction et mapping des voix (support des voix OpenAI alloy, echo, etc.)\n      const rawVoice =\n        (typeof body.voice === \"object\" ? body.voice?.name : body.voice) ||\n        \"flux-alexis-en\";\n      let voice = String(rawVoice).trim();\n      if (OPENAI_VOICE_MAP[voice.toLowerCase()]) {\n        voice = OPENAI_VOICE_MAP[voice.toLowerCase()];\n      }\n\n      const response_format = body.response_format ||\n        (body.audioConfig?.audioEncoding === \"OGG_OPUS\" ? \"opus\" : \"mp3\");\n      const speed = body.speed !== undefined\n        ? body.speed\n        : body.audioConfig?.speakingRate !== undefined\n        ? body.audioConfig.speakingRate\n        : 1.0;\n\n      if (!input) {\n        return c.json(\n          {\n            error: {\n              code: \"missing_input\",\n              message:\n                \"Le paramètre 'input' ou 'prompt' est obligatoire pour la synthèse vocale.\",\n              param: \"input\",\n              type: \"invalid_request_error\",\n            },\n          },\n          400,\n        );\n      }\n\n      // Règle stricte : filtrer par l'ID contenant ':free' quel que soit le forfait\n      const modelStr = String(model).toLowerCase().trim();\n      if (!modelStr.includes(\":free\")) {\n        return c.json(\n          {\n            error: {\n              code: \"speech_model_free_required\",\n              message:\n                `Pour l'API Speech, seuls les modèles avec ':free' sont autorisés (ex: 'deepgram/flux-tts:free'). Le modèle '${model}' n'est pas autorisé.`,\n              param: \"model\",\n              type: \"permission_error\",\n            },\n          },\n          403,\n        );\n      }\n\n      const sql = getDb();\n      const { weekStartStr, nextResetIso } = getWeekData();\n\n      // Vérifier le forfait réel de l'utilisateur\n      const uRows = await sql`\n        SELECT tier FROM users \n        WHERE id::text = ${userId}::text OR username = ${userId}::text \n        LIMIT 1\n      `.catch(() => []);\n      const keyTier = extractTierFromApiKey(token);\n      const effectiveTier = keyTier || uRows[0]?.tier || userPlan || \"Free\";\n      const audioBoost = await getUserQuotaBoost(sql, userId, \"audio\");\n      const weeklyLimit = getTierSpeechLimit(effectiveTier) + audioBoost;\n\n      // Estimation des tokens utilisés (environ 1 token pour ~3.5 caractères, min 1 token)\n      const estimatedTokens = Math.max(1, Math.ceil(input.length / 3.5));\n\n      // Vérification du quota hebdomadaire\n      const usageRows = await sql`\n        SELECT tokens_used \n        FROM weekly_speech_usage \n        WHERE user_id = ${userId}::text AND week_start = ${weekStartStr}::date \n        LIMIT 1\n      `.catch(() => []);\n      const currentUsage = Number(usageRows[0]?.tokens_used || 0);\n\n      if (currentUsage + estimatedTokens > weeklyLimit) {\n        return c.json(\n          {\n            error: {\n              code: \"weekly_speech_quota_exceeded\",\n              limit: weeklyLimit,\n              message:\n                `Votre quota hebdomadaire de tokens Speech est épuisé (${currentUsage}/${weeklyLimit} tokens pour le forfait ${effectiveTier}). Prochain renouvellement le ${nextResetIso}.`,\n              type: \"quota_error\",\n              used: currentUsage,\n            },\n          },\n          429,\n        );\n      }\n\n      // Récupération de la clé OpenRouter\n      const keyRows = await sql`\n        SELECT api_key FROM mprojects_api_keys WHERE user_id::text = ${userId}::text LIMIT 1\n      `.catch(() => []);\n      const openRouterApiKey = getOpenRouterApiKey(\n        keyRows.length > 0 ? keyRows[0].api_key : null,\n      );\n\n      if (!openRouterApiKey) {\n        return c.json(\n          { error: \"Clé fournisseur OpenRouter manquante côté serveur.\" },\n          500,\n        );\n      }\n\n      const openRouterPayload: Record = {\n        input,\n        model,\n        response_format,\n        speed,\n        voice,\n      };\n\n      const openRouterRes = await fetch(\n        \"https://openrouter.ai/api/v1/audio/speech\",\n        {\n          body: JSON.stringify(openRouterPayload),\n          headers: {\n            Authorization: `Bearer ${openRouterApiKey}`,\n            \"Content-Type\": \"application/json\",\n            \"HTTP-Referer\": \"https://mai.val.run\",\n            \"X-Title\": \"mAI Public API (Speech)\",\n          },\n          method: \"POST\",\n        },\n      );\n\n      if (!openRouterRes.ok) {\n        const errText = await openRouterRes.text().catch(() => \"\");\n        console.error(\"[OpenRouter Speech] Erreur retournée:\", errText);\n        return c.json(\n          {\n            details: errText,\n            error:\n              \"Erreur retournée par le fournisseur OpenRouter pour Speech.\",\n          },\n          openRouterRes.status,\n        );\n      }\n\n      // Récupérer le buffer binaire audio\n      const arrayBuf = await openRouterRes.arrayBuffer();\n      const bytes = new Uint8Array(arrayBuf);\n      let binary = \"\";\n      for (let i = 0; i < bytes.byteLength; i++) {\n        binary += String.fromCharCode(bytes[i]);\n      }\n      const base64Audio = btoa(binary);\n      const mimeType = response_format === \"opus\"\n        ? \"audio/opus\"\n        : response_format === \"wav\"\n        ? \"audio/wav\"\n        : \"audio/mpeg\";\n      const dataUrl = `data:${mimeType};base64,${base64Audio}`;\n\n      // Incrémentation atomique du quota hebdomadaire de tokens Speech\n      try {\n        await sql`\n          INSERT INTO weekly_speech_usage (user_id, week_start, tokens_used, requests_count, updated_at)\n          VALUES (${userId}::text, ${weekStartStr}::date, ${estimatedTokens}, 1, NOW())\n          ON CONFLICT (user_id, week_start)\n          DO UPDATE SET \n            tokens_used = weekly_speech_usage.tokens_used + ${estimatedTokens},\n            requests_count = weekly_speech_usage.requests_count + 1,\n            updated_at = NOW()\n        `;\n      } catch (err) {\n        console.error(\"[Speech API] Erreur update weekly_speech_usage:\", err);\n      }\n\n      // Log dans l'historique mprojects_speech_generations\n      let savedId = Date.now();\n      try {\n        const insertRes = await sql`\n          INSERT INTO mprojects_speech_generations (\n            user_id, api_key, model, voice, input_text, audio_url, tokens_count, character_count, status, created_at\n          ) VALUES (\n            ${userId}::text,\n            ${apiKey || null},\n            ${model}::text,\n            ${voice}::text,\n            ${input}::text,\n            ${dataUrl}::text,\n            ${estimatedTokens}::integer,\n            ${input.length}::integer,\n            'completed',\n            NOW()\n          ) RETURNING id\n        `;\n        if (insertRes.length > 0 && insertRes[0].id) {\n          savedId = insertRes[0].id;\n        }\n      } catch {}\n\n      // Log dans mprojects_api_logs\n      try {\n        await sql`\n          INSERT INTO mprojects_api_logs (api_key, endpoint, method, status_code, latency_ms, created_at)\n          VALUES (${apiKey || \"jwt\"}::text, ${\n          reqPath || \"/v1/speech\"\n        }::text, 'POST', 200, 500, NOW())\n        `;\n      } catch {}\n\n      // Vérifier si le client attend du JSON (outil IA, studio web, ou Google TTS)\n      const acceptsJson =\n        c.req.header(\"accept\")?.includes(\"application/json\") ||\n        body.return_json ||\n        body.response_format === \"json\" ||\n        body.format === \"json\" ||\n        isGoogleTts;\n\n      if (acceptsJson) {\n        return c.json({\n          audio_url: dataUrl,\n          audioContent: base64Audio,\n          character_count: input.length,\n          created: Math.floor(Date.now() / 1000),\n          format: response_format,\n          id: savedId,\n          model: cleanModelName(model),\n          model_id: model,\n          status: \"completed\",\n          text: input,\n          tokens_used: estimatedTokens,\n          usage: {\n            requests_count: currentUsage + 1,\n            tokens_used: estimatedTokens,\n            weekly_limit: weeklyLimit,\n            weekly_used: currentUsage + estimatedTokens,\n          },\n          voice,\n        });\n      }\n\n      // Format binaire standard pour OpenAI SDK & requêtes natives\n      // (CORS géré par le middleware global dans main.ts)\n      return new Response(bytes, {\n        headers: {\n          \"Content-Type\": mimeType,\n          \"x-audio-id\": String(savedId),\n          \"x-speech-limit\": String(weeklyLimit),\n          \"x-speech-used\": String(currentUsage + estimatedTokens),\n          \"x-tokens-used\": String(estimatedTokens),\n        },\n        status: 200,\n      });\n    } catch (err: any) {\n      console.error(\"[Speech API] Erreur serveur:\", err);\n      return c.json(\n        {\n          details: err.message,\n          error: \"Erreur serveur lors du traitement Speech.\",\n        },\n        500,\n      );\n    }\n  };\n\n  // Routes OpenAI & Anthropic SDK\n  app.post(\"/v1/speech\", handleAudioSpeech);\n  app.post(\"/speech\", handleAudioSpeech);\n  app.post(\"/v1/speech/generations\", handleAudioSpeech);\n  app.post(\"/speech/generations\", handleAudioSpeech);\n  app.post(\"/v1/audio/speech\", handleAudioSpeech);\n  app.post(\"/v1/audio/generations\", handleAudioSpeech);\n  app.post(\"/audio/speech\", handleAudioSpeech);\n  app.post(\"/audio/generations\", handleAudioSpeech);\n  app.post(\"/api/vibe/speech\", handleAudioSpeech);\n  app.post(\"/vibe/speech\", handleAudioSpeech);\n  app.post(\"/api/speech\", handleAudioSpeech);\n  app.post(\"/api/v1/speech\", handleAudioSpeech);\n  app.post(\"/api/v1/audio/speech\", handleAudioSpeech);\n  app.post(\"/api/vibe/audio/speech\", handleAudioSpeech);\n\n  // Routes Google Cloud TTS / Gemini SDK\n  app.post(\"/v1beta/models/*:synthesizeSpeech\", handleAudioSpeech);\n  app.post(\"/v1/models/*:synthesizeSpeech\", handleAudioSpeech);\n  app.post(\"/v1beta/speech:synthesize\", handleAudioSpeech);\n  app.post(\"/v1/speech:synthesize\", handleAudioSpeech);\n}",[201],"60b8bc13-9c84-453d-ae1e-cdcedb52c2a2",231,["D",1788678953719],25,"import type { Hono } from \"npm:hono@4\";\nimport {\n  extractTierFromApiKey,\n  getDb,\n  getTierRequestLimit,\n  getUserQuotaBoost,\n  getWeekData,\n  verifyToken,\n} from \"./config.ts\";\n\nexport function registerMiddleware(app: Hono) {\n  // Middleware global pour Auth, Rate limiting & Logging sur toutes les routes d'API\n  app.use(\"*\", async (c, next) => {\n    // Preflight CORS : laisser passer sans auth (géré par le middleware CORS de main.ts)\n    if (c.req.method === \"OPTIONS\") {\n      await next();\n      return;\n    }\n\n    const path = c.req.path;\n\n    // Détection des routes d'API\n    const isApiRoute = path.startsWith(\"/v1/\") ||\n      path.startsWith(\"/v1beta/\") ||\n      path === \"/v1/models\" ||\n      path === \"/models\" ||\n      path.startsWith(\"/models/\") ||\n      path === \"/v1beta/models\" ||\n      path === \"/chat/completions\" ||\n      path.startsWith(\"/chat/\") ||\n      path === \"/messages\" ||\n      path.startsWith(\"/messages/\") ||\n      path === \"/speech\" ||\n      path.startsWith(\"/speech/\") ||\n      path === \"/images\" ||\n      path.startsWith(\"/images/\") ||\n      path === \"/images/generations\" ||\n      path === \"/mj\" ||\n      path.startsWith(\"/mj/\") ||\n      path.startsWith(\"/v1/mj/\") ||\n      path === \"/audio/speech\" ||\n      path.startsWith(\"/audio/\") ||\n      path === \"/usage/speech\" ||\n      path === \"/v1/usage/speech\" ||\n      path === \"/usage\" ||\n      path === \"/v1/usage\" ||\n      path === \"/log-usage\" ||\n      path === \"/v1/log-usage\" ||\n      path === \"/v1/status\" ||\n      path === \"/status\";\n\n    if (!isApiRoute) {\n      await next();\n      return;\n    }\n\n    const isPublicRoute = path === \"/\" ||\n      path === \"/api\" ||\n      path === \"/api/\" ||\n      path === \"/v1\" ||\n      path === \"/v1/\" ||\n      path === \"/vibe\" ||\n      path === \"/vibe/\" ||\n      path === \"/api/vibe\" ||\n      path === \"/api/vibe/\" ||\n      path === \"/v1/login\" ||\n      path === \"/v1/register\" ||\n      path === \"/v1/verify-login\" ||\n      path === \"/v1/verify-register\" ||\n      path === \"/v1/resend-code\" ||\n      path.startsWith(\"/v1/feed\") ||\n      path.startsWith(\"/api/vibe/feed\") ||\n      path.startsWith(\"/vibe/feed\") ||\n      path === \"/feed\" ||\n      path.startsWith(\"/v1/posts\") ||\n      path.startsWith(\"/api/vibe/posts\") ||\n      path.startsWith(\"/v1/trends\") ||\n      path.startsWith(\"/api/vibe/trends\") ||\n      path.startsWith(\"/v1/profiles\") ||\n      path.startsWith(\"/api/vibe/profiles\") ||\n      path.startsWith(\"/v1/search\") ||\n      path.startsWith(\"/api/vibe/search\") ||\n      path.startsWith(\"/vibe/search\") ||\n      path.startsWith(\"/search\") ||\n      path === \"/v1/models\" ||\n      path === \"/models\" ||\n      path === \"/v1beta/models\" ||\n      path === \"/v1/models/images\" ||\n      path === \"/models/images\" ||\n      path === \"/v1/images/models\" ||\n      path === \"/images/models\" ||\n      path.startsWith(\"/v1/models/images/\") ||\n      path.startsWith(\"/models/images/\") ||\n      path === \"/v1/models/speech\" ||\n      path === \"/models/speech\" ||\n      path === \"/v1/speech/models\" ||\n      path === \"/speech/models\" ||\n      path === \"/v1/speech/voices\" ||\n      path === \"/speech/voices\" ||\n      path === \"/v1/audio/models\" ||\n      path === \"/v1/audio/voices\" ||\n      path === \"/v1/models/mai\" ||\n      path === \"/v1/mai/models\" ||\n      path === \"/models/mai\" ||\n      path === \"/mai/models\" ||\n      path === \"/v1/status\" ||\n      path === \"/status\" ||\n      path === \"/v1/web/search\" ||\n      path.startsWith(\"/v1/web/\");\n\n    const authHeader = c.req.header(\"Authorization\") ||\n      c.req.header(\"authorization\");\n    const headerApiKey = c.req.header(\"x-api-key\") ||\n      c.req.header(\"X-API-Key\") ||\n      c.req.header(\"x-goog-api-key\") ||\n      c.req.header(\"X-Goog-Api-Key\");\n    const queryApiKey = c.req.query(\"api_key\") ||\n      c.req.query(\"key\") ||\n      // JWT de session en query : requis pour le flux SSE (EventSource ne\n      // peut pas définir d'en-têtes) — cf. realtime.ts /v1/realtime/stream\n      c.req.query(\"token\");\n\n    let rawApiKey =\n      (authHeader?.startsWith(\"Bearer \") ? authHeader.slice(7) : authHeader) ||\n      headerApiKey ||\n      queryApiKey ||\n      null;\n\n    if (rawApiKey) {\n      rawApiKey = rawApiKey.trim();\n      if (\n        rawApiKey === \"\" ||\n        rawApiKey === \"null\" ||\n        rawApiKey === \"undefined\" ||\n        rawApiKey === \"Bearer\"\n      ) {\n        rawApiKey = null;\n      }\n    }\n\n    const apiKey = rawApiKey;\n    const reqUserId = c.req.header(\"x-user-id\") || c.req.header(\"X-User-Id\");\n    const startTime = Date.now();\n\n    const systemMaiApiKey = Deno.env.get(\"MAI_API_KEY\");\n\n    let userPlan = \"Free\";\n    let currentUserId: string | null = null;\n    const currentApiKey: string | null = apiKey;\n    let matchedApiKey: string | null = apiKey;\n    // Authentification par clé API enregistrée (par opposition à un JWT de session ou à la clé système)\n    let isRegisteredApiKey = false;\n\n    function timingSafeEqual(a: string, b: string): boolean {\n      if (a.length !== b.length) {\n        return false;\n      }\n      let diff = 0;\n      for (let i = 0; i < a.length; i++) {\n        diff |= a.charCodeAt(i) ^ b.charCodeAt(i);\n      }\n      return diff === 0;\n    }\n\n    // Résolution de l'authentification : Clé API utilisateur enregistrée, Clé système, ou Token JWT\n    if (apiKey) {\n      // Détection prioritaire du forfait directement encodé dans la clé (mai-TIER_USER-XXXXX-XXXXX)\n      const keyTier = extractTierFromApiKey(apiKey);\n      if (keyTier) {\n        userPlan = keyTier;\n      }\n\n      const sql = getDb();\n      try {\n        const rows = await sql`\n          SELECT k.*, u.tier as user_tier, u.id as u_id\n          FROM mprojects_api_keys k\n          LEFT JOIN users u ON k.user_id = u.id::text OR k.user_id = u.username OR k.user_id = u.email\n          WHERE k.api_key = ${apiKey}::text\n          LIMIT 1\n        `;\n\n        if (rows.length > 0) {\n          const apiKeyData = rows[0];\n          // Si le TIER_USER a été extrait de la clé fournie, il fait foi en priorité\n          if (!keyTier) {\n            const rawPlan = String(apiKeyData.plan || \"\").trim().toLowerCase();\n            const validTiers = [\"free\", \"plus\", \"pro\", \"max\"];\n            userPlan = apiKeyData.user_tier ||\n              (validTiers.includes(rawPlan) ? apiKeyData.plan : \"Plus\");\n          }\n          currentUserId = apiKeyData.user_id;\n          matchedApiKey = apiKeyData.api_key || apiKey;\n          isRegisteredApiKey = true;\n        } else if (\n          systemMaiApiKey && timingSafeEqual(apiKey, systemMaiApiKey)\n        ) {\n          userPlan = \"Plus\";\n          currentUserId = \"system-mai\";\n        } else {\n          // Tenter de valider le token comme un JWT de session\n          try {\n            const payload = await verifyToken(apiKey);\n            currentUserId = String(payload.sub || \"\");\n            userPlan = String(payload.tier || \"Free\");\n\n            // Vérifier dans la table users si le forfait a changé\n            if (currentUserId) {\n              const uRows = await sql`\n                SELECT tier FROM users\n                WHERE id::text = ${currentUserId}::text OR username = ${currentUserId}::text OR email = ${currentUserId}::text\n                LIMIT 1\n              `;\n              if (uRows.length > 0 && uRows[0].tier) {\n                userPlan = uRows[0].tier;\n              }\n            }\n          } catch {\n            if (!isPublicRoute) {\n              return c.json({ error: \"Invalid API Key.\" }, 403);\n            }\n          }\n        }\n      } catch (dbErr) {\n        console.error(\"Auth DB Error in middleware:\", dbErr);\n      }\n    }\n\n    // 3. En-tête x-user-id (requêtes web app / internes) : uniquement si déjà authentifié ou fallback route publique\n    if (reqUserId && reqUserId !== \"system-mai\") {\n      if (currentUserId) {\n        // Déjà authentifié via clé API ou JWT : x-user-id doit correspondre, sinon on l'ignore\n        if (reqUserId !== currentUserId) {\n          console.warn(\n            `[Auth] x-user-id mismatch: header=${reqUserId} vs auth=${currentUserId} — header ignoré`,\n          );\n        }\n      } else if (apiKey) {\n        // apiKey présent mais non reconnu (route publique) : ne pas promouvoir via x-user-id seul\n      } else {\n        // Aucune auth vérifiée\n        try {\n          const sql = getDb();\n          const uRows = await sql`\n            SELECT tier FROM users \n            WHERE id::text = ${reqUserId}::text OR username = ${reqUserId}::text OR email = ${reqUserId}::text \n            LIMIT 1\n          `;\n          if (uRows.length > 0) {\n            if (uRows[0].tier) {\n              userPlan = uRows[0].tier;\n            }\n            if (isPublicRoute) {\n              currentUserId = reqUserId;\n            } else {\n              console.warn(\n                `[Auth] x-user-id sans JWT sur route privée ${path} — ignoré`,\n              );\n            }\n          }\n        } catch {}\n      }\n    }\n\n    // 4. Aucun identifiant et route privée\n    if (!apiKey && !currentUserId && !isPublicRoute) {\n      return c.json({ error: \"Service Unavailable. API Key missing.\" }, 401);\n    }\n\n    // Enregistrer le plan et les infos de contexte\n    c.set(\"userPlan\", userPlan);\n    c.set(\"userId\", currentUserId);\n    c.set(\"apiKey\", currentApiKey);\n    c.set(\"matchedApiKey\", matchedApiKey);\n\n    // Vérification préventive du quota de requêtes pour les clés API enregistrées.\n    // Le solde est global au compte (cumul de toutes ses clés) et la période est hebdomadaire\n    // (lundi 00:00 UTC), marquée par usage_period_start pour un reset idempotent.\n    // Un token JWT de session ne consomme pas ce quota : la requête est exécutée directement.\n    if (isRegisteredApiKey && currentUserId && currentUserId !== \"system-mai\") {\n      const sql = getDb();\n      const { nextResetIso, weekStartStr } = getWeekData();\n      const apiBoost = await getUserQuotaBoost(sql, currentUserId, \"api\");\n      const limit = getTierRequestLimit(userPlan) + apiBoost;\n\n      try {\n        await sql`\n          UPDATE mprojects_api_keys\n          SET request_count = 0, usage_period_start = ${weekStartStr}::date\n          WHERE user_id::text = ${currentUserId}::text\n            AND usage_period_start IS DISTINCT FROM ${weekStartStr}::date\n        `;\n\n        const countRows = await sql`\n          SELECT SUM(request_count) as total_requests\n          FROM mprojects_api_keys\n          WHERE user_id::text = ${currentUserId}::text\n        `;\n        // Neon renvoie les bigint en chaîne: Number() est obligatoire pour comparer\n        const used = Number(countRows[0]?.total_requests || 0);\n        const remaining = Math.max(0, limit - used);\n\n        (c as any).set(\"requestQuota\", {\n          apiKey: matchedApiKey,\n          limit,\n          remaining,\n          used,\n        });\n\n        if (remaining < 1) {\n          if (isPublicRoute) {\n            await next();\n            return;\n          }\n          return c.json({\n            code: \"quota_exceeded\",\n            error: \"Quota exceeded for your account.\",\n            limit,\n            remaining,\n            resetAt: nextResetIso,\n            used,\n          }, 429);\n        }\n      } catch {}\n    }\n\n    await next();\n\n    const latency = Date.now() - startTime;\n    const status = c.res.status;\n    const endpoint = c.req.path;\n    const method = c.req.method;\n\n    // Log-usage & Décompte de 1 requête du quota API (chat, audio, images, web search, etc.).\n    // Uniquement pour les clés API enregistrées : +1 requête au solde hebdomadaire du\n    // propriétaire de la clé. Les requêtes authentifiées par JWT de session sont\n    // exécutées directement, sans log-usage ni débit ensuite.\n    const isExcludedRoute = path.startsWith(\"/v1/devices\") ||\n      path === \"/v1/status\" || path === \"/status\";\n    if (!isExcludedRoute && isRegisteredApiKey) {\n      try {\n        const sql = getDb();\n        const effectiveKeyToLog = matchedApiKey || apiKey;\n\n        await sql`\n          INSERT INTO mprojects_api_logs (api_key, endpoint, method, status_code, latency_ms)\n          VALUES (${effectiveKeyToLog}::text, ${endpoint}::text, ${method}::text, ${status}::integer, ${latency}::integer)\n        `;\n\n        // Les routes qui débitent elles-mêmes un coût multi-crédits (images) posent le fanion\n        // pour éviter le double débit `cout + 1` sur la même requête.\n        if (status === 200 && !(c as any).get?.(\"quotaDebitedByHandler\")) {\n          await sql`\n            UPDATE mprojects_api_keys\n            SET request_count = request_count + 1, last_used_at = NOW()\n            WHERE api_key = ${effectiveKeyToLog}::text\n          `;\n        }\n      } catch (err) {\n        console.error(\"Erreur logging API & mise à jour quota:\", err);\n      }\n    }\n  });\n}",[217],"pulls","branches","forks","envVars",{"_703":96,"_706":26},"connections",{"_703":704,"_705":26},"count",1,"unfilledCount","emptyCount",{"_51":690,"_15":217,"_53":227,"_55":-5,"_56":77,"_58":691,"_60":24,"_61":880,"_63":693,"_65":66,"_67":694,"_31":69,"_70":-5,"_71":881,"_45":882},{"_51":685,"_15":201,"_53":211,"_55":-5,"_56":77,"_58":686,"_60":24,"_61":877,"_63":616,"_65":66,"_67":688,"_31":69,"_70":-5,"_71":878,"_45":879},{"_51":679,"_15":185,"_53":195,"_55":-5,"_56":77,"_58":680,"_60":24,"_61":874,"_63":682,"_65":66,"_67":683,"_31":69,"_70":-5,"_71":875,"_45":876},{"_51":675,"_15":168,"_53":178,"_55":-5,"_56":77,"_58":639,"_60":24,"_61":871,"_63":538,"_65":66,"_67":677,"_31":69,"_70":-5,"_71":872,"_45":873},{"_51":669,"_15":670,"_53":671,"_55":-5,"_56":77,"_58":228,"_60":24,"_61":868,"_63":616,"_65":66,"_67":673,"_31":69,"_70":-5,"_71":869,"_45":870},{"_51":666,"_15":151,"_53":161,"_55":-5,"_56":77,"_58":639,"_60":24,"_61":865,"_63":538,"_65":66,"_67":157,"_31":69,"_70":-5,"_71":866,"_45":867},{"_51":663,"_15":135,"_53":145,"_55":-5,"_56":77,"_58":246,"_60":24,"_61":862,"_63":601,"_65":66,"_67":141,"_31":69,"_70":-5,"_71":863,"_45":864},{"_51":657,"_15":658,"_53":659,"_55":-5,"_56":77,"_58":113,"_60":24,"_61":859,"_63":26,"_65":66,"_67":661,"_31":69,"_70":-5,"_71":860,"_45":861},{"_51":649,"_15":650,"_53":285,"_55":-5,"_56":77,"_58":651,"_60":24,"_61":856,"_63":653,"_65":654,"_67":655,"_31":69,"_70":16,"_71":857,"_45":858},{"_51":643,"_15":118,"_53":128,"_55":-5,"_56":77,"_58":644,"_60":24,"_61":853,"_63":646,"_65":66,"_67":647,"_31":69,"_70":-5,"_71":854,"_45":855},{"_51":638,"_15":102,"_53":112,"_55":-5,"_56":77,"_58":639,"_60":24,"_61":850,"_63":98,"_65":66,"_67":641,"_31":69,"_70":-5,"_71":851,"_45":852},{"_51":631,"_15":632,"_53":633,"_55":-5,"_56":77,"_58":634,"_60":24,"_61":847,"_63":80,"_65":66,"_67":636,"_31":69,"_70":-5,"_71":848,"_45":849},{"_51":626,"_15":84,"_53":95,"_55":-5,"_56":77,"_58":627,"_60":24,"_61":844,"_63":415,"_65":66,"_67":629,"_31":69,"_70":-5,"_71":845,"_45":846},{"_51":619,"_15":620,"_53":621,"_55":-5,"_56":77,"_58":622,"_60":24,"_61":841,"_63":80,"_65":66,"_67":624,"_31":69,"_70":-5,"_71":842,"_45":843},{"_51":611,"_15":612,"_53":613,"_55":-5,"_56":77,"_58":614,"_60":24,"_61":838,"_63":616,"_65":66,"_67":617,"_31":69,"_70":-5,"_71":839,"_45":840},{"_51":604,"_15":605,"_53":606,"_55":-5,"_56":77,"_58":607,"_60":24,"_61":835,"_63":64,"_65":66,"_67":609,"_31":69,"_70":-5,"_71":836,"_45":837},{"_51":596,"_15":597,"_53":598,"_55":-5,"_56":77,"_58":599,"_60":24,"_61":832,"_63":601,"_65":66,"_67":602,"_31":69,"_70":-5,"_71":833,"_45":834},{"_51":589,"_15":590,"_53":591,"_55":-5,"_56":77,"_58":592,"_60":24,"_61":829,"_63":80,"_65":66,"_67":594,"_31":69,"_70":-5,"_71":830,"_45":831},{"_51":583,"_15":584,"_53":585,"_55":-5,"_56":77,"_58":278,"_60":24,"_61":826,"_63":98,"_65":66,"_67":587,"_31":69,"_70":-5,"_71":827,"_45":828},{"_51":576,"_15":577,"_53":578,"_55":-5,"_56":77,"_58":579,"_60":24,"_61":823,"_63":90,"_65":66,"_67":581,"_31":69,"_70":-5,"_71":824,"_45":825},{"_51":569,"_15":570,"_53":571,"_55":-5,"_56":77,"_58":572,"_60":24,"_61":820,"_63":90,"_65":66,"_67":574,"_31":69,"_70":-5,"_71":821,"_45":822},{"_51":562,"_15":563,"_53":564,"_55":-5,"_56":77,"_58":565,"_60":24,"_61":817,"_63":64,"_65":66,"_67":567,"_31":69,"_70":-5,"_71":818,"_45":819},{"_51":555,"_15":556,"_53":557,"_55":-5,"_56":77,"_58":558,"_60":24,"_61":814,"_63":64,"_65":66,"_67":560,"_31":69,"_70":-5,"_71":815,"_45":816},{"_51":548,"_15":549,"_53":550,"_55":-5,"_56":77,"_58":551,"_60":24,"_61":811,"_63":64,"_65":66,"_67":553,"_31":69,"_70":-5,"_71":812,"_45":813},{"_51":541,"_15":542,"_53":543,"_55":-5,"_56":77,"_58":544,"_60":24,"_61":808,"_63":64,"_65":66,"_67":546,"_31":69,"_70":-5,"_71":809,"_45":810},{"_51":533,"_15":534,"_53":535,"_55":-5,"_56":77,"_58":536,"_60":24,"_61":805,"_63":538,"_65":66,"_67":539,"_31":69,"_70":-5,"_71":806,"_45":807},{"_51":526,"_15":527,"_53":528,"_55":-5,"_56":77,"_58":529,"_60":24,"_61":802,"_63":98,"_65":66,"_67":531,"_31":69,"_70":-5,"_71":803,"_45":804},{"_51":519,"_15":520,"_53":521,"_55":-5,"_56":77,"_58":522,"_60":24,"_61":799,"_63":64,"_65":66,"_67":524,"_31":69,"_70":-5,"_71":800,"_45":801},{"_51":512,"_15":513,"_53":514,"_55":-5,"_56":77,"_58":515,"_60":24,"_61":796,"_63":64,"_65":66,"_67":517,"_31":69,"_70":-5,"_71":797,"_45":798},{"_51":505,"_15":506,"_53":507,"_55":-5,"_56":77,"_58":508,"_60":24,"_61":793,"_63":64,"_65":66,"_67":510,"_31":69,"_70":-5,"_71":794,"_45":795},{"_51":498,"_15":499,"_53":500,"_55":-5,"_56":77,"_58":501,"_60":24,"_61":790,"_63":64,"_65":66,"_67":503,"_31":69,"_70":-5,"_71":791,"_45":792},{"_51":490,"_15":491,"_53":492,"_55":-5,"_56":77,"_58":493,"_60":24,"_61":787,"_63":495,"_65":66,"_67":496,"_31":69,"_70":-5,"_71":788,"_45":789},{"_51":483,"_15":484,"_53":485,"_55":-5,"_56":77,"_58":486,"_60":24,"_61":784,"_63":64,"_65":66,"_67":488,"_31":69,"_70":-5,"_71":785,"_45":786},{"_51":476,"_15":477,"_53":478,"_55":-5,"_56":77,"_58":479,"_60":24,"_61":781,"_63":230,"_65":66,"_67":481,"_31":69,"_70":-5,"_71":782,"_45":783},{"_51":469,"_15":470,"_53":471,"_55":-5,"_56":77,"_58":472,"_60":24,"_61":778,"_63":80,"_65":66,"_67":474,"_31":69,"_70":-5,"_71":779,"_45":780},{"_51":462,"_15":463,"_53":464,"_55":-5,"_56":77,"_58":465,"_60":24,"_61":775,"_63":80,"_65":66,"_67":467,"_31":69,"_70":-5,"_71":776,"_45":777},{"_51":455,"_15":456,"_53":457,"_55":-5,"_56":77,"_58":458,"_60":24,"_61":772,"_63":80,"_65":66,"_67":460,"_31":69,"_70":-5,"_71":773,"_45":774},{"_51":447,"_15":448,"_53":449,"_55":-5,"_56":77,"_58":450,"_60":24,"_61":769,"_63":452,"_65":66,"_67":453,"_31":69,"_70":-5,"_71":770,"_45":771},{"_51":440,"_15":441,"_53":442,"_55":-5,"_56":77,"_58":443,"_60":24,"_61":766,"_63":164,"_65":66,"_67":445,"_31":69,"_70":-5,"_71":767,"_45":768},{"_51":433,"_15":434,"_53":435,"_55":-5,"_56":77,"_58":436,"_60":24,"_61":763,"_63":423,"_65":66,"_67":438,"_31":69,"_70":-5,"_71":764,"_45":765},{"_51":426,"_15":427,"_53":428,"_55":-5,"_56":77,"_58":429,"_60":24,"_61":760,"_63":64,"_65":66,"_67":431,"_31":69,"_70":-5,"_71":761,"_45":762},{"_51":418,"_15":419,"_53":420,"_55":-5,"_56":77,"_58":421,"_60":24,"_61":757,"_63":423,"_65":66,"_67":424,"_31":69,"_70":-5,"_71":758,"_45":759},{"_51":410,"_15":411,"_53":412,"_55":-5,"_56":77,"_58":413,"_60":24,"_61":754,"_63":415,"_65":66,"_67":416,"_31":69,"_70":-5,"_71":755,"_45":756},{"_51":407,"_15":46,"_53":76,"_55":-5,"_56":77,"_58":246,"_60":24,"_61":751,"_63":181,"_65":66,"_67":68,"_31":69,"_70":-5,"_71":752,"_45":753},["D",1788164141214],[],[46],["D",1789229562093],[],[411],["D",1789229641719],[],[419],["D",1789232449909],[],[427],["D",1789232416588],[],[434],["D",1789204570685],[],[441],["D",1789146610117],[],[448],["D",1789229665577],[],[456],["D",1789229675080],[],[463],["D",1789229573039],[],[470],["D",1789313578830],[],[477],["D",1789313699618],[],[484],["D",1789229654431],[],[491],["D",1789313606037],[],[499],["D",1789313672518],[],[506],["D",1789313630313],[],[513],["D",1789313654225],[],[520],["D",1789229613228],[],[527],["D",1789233612605],[],[534],["D",1789233648949],[],[542],["D",1789233631883],[],[549],["D",1789233728377],[],[556],["D",1789233699297],[],[563],["D",1789311921611],[],[570],["D",1789313754778],[],[577],["D",1789315877037],[],[584],["D",1789315868425],[],[590],["D",1789312015279],[],[597],["D",1789313726383],[],[605],["D",1789145746117],[],[612],["D",1788800889123],[],[620],["D",1789145672482],[],[84],["D",1789229709739],[],[632],["D",1788618643754],[],[102],["D",1788620602782],[],[118],["D",1788714800578],[],[650],["D",1787587613987],[],[658],["D",1788164141214],[],[135],["D",1788618643754],[],[151],["D",1787754938926],[],[670],["D",1788618643754],[],[168],["D",1789229716185],[],[185],["D",1788800899725],[],[201],["D",1788678953719],[],[217],["D",1785339526786],["D",1789474235934],{"_13":14,"_323":264},{"_13":14,"_318":319,"_263":264,"_282":283,"_320":321,"_322":69},{"_63":278,"_15":277,"_51":77,"_271":265,"_272":-5,"_273":-5,"_315":-5,"_316":-5,"_317":-5,"_275":16,"_274":14},"ctx",{"_308":-5,"_360":921,"_922":923,"_924":925,"_926":69,"_927":69,"_928":69,"_929":24,"_930":-5,"_931":-7,"_932":-7,"_933":26,"_934":69,"_935":69,"_936":-5,"_937":69,"_938":69,"_939":69,"_940":-5},"ENV",{"_892":893,"_894":895,"_896":277,"_897":898,"_899":900,"_901":902,"_903":904,"_905":906,"_907":908,"_909":910,"_911":912,"_913":914,"_915":916,"_917":918,"_919":920},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]
Pull requests

api-middleware.ts+57-25

audio.ts+86-9

auth.ts+27-2

config.ts+129-90

email.ts+18-4

images.ts+131-35

models.ts+44-41

projects.ts+219-23

storage.ts+183-380

web.ts+0-1
