[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_311":312,"_313":314},"routes/_app.x.$handle.$name",{"_101":100,"_32":45,"_110":91,"_27":111,"_13":14,"_112":-5,"_11":113,"_114":115,"_116":117,"_118":119,"_120":121,"_20":-5,"_122":-5,"_123":-5,"_124":25,"_125":126,"_127":60,"_128":-5,"_129":-5,"_130":131},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_43":44,"_32":45,"_38":46,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":55,"_18":56,"_57":58,"_59":60,"_61":-5,"_62":-5,"_63":64,"_65":66,"_67":68,"_69":70,"_71":72,"_73":-5,"_74":75,"_76":75,"_77":78,"_79":78,"_80":78,"_81":75,"_82":75,"_83":84,"_85":86,"_87":88,"_89":25},"version",119,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":34,"_35":37,"_38":39,"_40":14,"_41":42,"_24":25},"previous",{"_30":31,"_32":28,"_33":34,"_35":36},"deleted",false,"deletedHere","path","email.ts","latestPath","fileId","e9725edc-9c6a-11f1-8111-1607ee4eb77e","name","fileType","script","content","import nodemailer from \"nodemailer\";\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

\n \n \n `;\n\n return await sendHtmlEmail(recipientEmail, subject, html);\n}","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 $\"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 $\"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

\n \n \n `;\n\n return await sendHtmlEmail(recipientEmail, subject, html);\n}","createdAt",["D",1787929713599],"branchVersion","branchId","3345cb6c-eeb2-4b61-ab03-8e0abc2dcd73","id","200f8efb-f4ef-4117-ae26-ee737dbffb76","mai",["D",1785339526786],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Avec l'API d'mAI, récupérez des données sur les projets !","imageUrl","https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/cdf5d0c3-f220-4dec-712e-87455a037c00/square512?exp=1789577999&sig=cd0c0097b0cb42757443c3579677f4fee0b08c685bbb24906b0b3bc7adeffab2","7ed13655-83c2-4934-a981-01578302df33","pinnedFileId","968028a2-8b63-11f1-b718-1607ee4eb77e","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","019f99eb-d944-7332-99f8-2fbb8b1e7011","tursoName","200f8efbf4ef4117ae26ee737dbffb76","tursoHostname","200f8efbf4ef4117ae26ee737dbffb76-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789561254403],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_101":100,"_109":105},"org",{"_101":100,"_102":103,"_104":105,"_18":56,"_106":107,"_108":25},"branch",{"_13":90,"_32":91,"_43":42,"_92":44,"_93":-5,"_94":-5,"_95":-5,"_96":-5,"_97":-5,"_98":45,"_99":100},"isOwned",364,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","mdevslabs","handle","displayName","mProjects","avatar","https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/ec72623f-c02d-461a-9b1c-c2f416214400/square512?exp=1789577999&sig=3483dd20b0f87958073241ce44e16cd0bef881e993fd6e57fbd3706ee563cdf8","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_43":44,"_32":45,"_38":306,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":55,"_18":56,"_57":58,"_59":60,"_61":-5,"_62":-5,"_63":64,"_65":66,"_67":68,"_69":70,"_71":307,"_73":-5,"_74":75,"_76":75,"_77":78,"_79":78,"_80":78,"_81":75,"_82":75,"_83":308,"_85":309,"_87":310,"_89":25},"tree",[253,254,255,256,257,258,259,260,261,262,263,264,265],"files",[253,254,255,256,257,258,259,260,261,262,263,264,265],"counts",{"_241":64,"_242":243,"_244":64,"_245":246,"_247":248},"contents",[132,133,134,135,136,137,138,139,140,141,142,143,144],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_43":234,"_32":235,"_30":236,"_148":-5,"_41":42,"_40":208,"_150":25,"_38":237,"_13":238,"_33":34,"_35":239,"_24":25,"_154":-5,"_27":240},{"_43":227,"_32":228,"_30":229,"_148":-5,"_41":42,"_40":230,"_150":25,"_38":231,"_13":169,"_33":34,"_35":232,"_24":25,"_154":-5,"_27":233},{"_43":220,"_32":221,"_30":222,"_148":-5,"_41":42,"_40":223,"_150":25,"_38":224,"_13":217,"_33":34,"_35":225,"_24":25,"_154":-5,"_27":226},{"_43":213,"_32":214,"_30":215,"_148":-5,"_41":42,"_40":182,"_150":25,"_38":216,"_13":217,"_33":34,"_35":218,"_24":25,"_154":-5,"_27":219},{"_43":205,"_32":206,"_30":207,"_148":-5,"_41":42,"_40":208,"_150":60,"_38":209,"_13":210,"_33":34,"_35":211,"_24":25,"_154":-5,"_27":212},{"_43":201,"_32":28,"_30":31,"_148":-5,"_41":42,"_40":14,"_150":25,"_38":202,"_13":203,"_33":34,"_35":37,"_24":25,"_154":-5,"_27":204},{"_43":194,"_32":195,"_30":196,"_148":-5,"_41":42,"_40":197,"_150":25,"_38":198,"_13":161,"_33":34,"_35":199,"_24":25,"_154":-5,"_27":200},{"_43":188,"_32":189,"_30":190,"_148":-5,"_41":42,"_40":167,"_150":60,"_38":191,"_13":64,"_33":34,"_35":192,"_24":25,"_154":-5,"_27":193},{"_43":180,"_32":181,"_30":58,"_148":-5,"_41":42,"_40":182,"_150":25,"_38":183,"_13":184,"_33":185,"_35":186,"_24":25,"_154":45,"_27":187},{"_43":172,"_32":173,"_30":174,"_148":-5,"_41":42,"_40":175,"_150":25,"_38":176,"_13":177,"_33":34,"_35":178,"_24":25,"_154":-5,"_27":179},{"_43":164,"_32":165,"_30":166,"_148":-5,"_41":42,"_40":167,"_150":25,"_38":168,"_13":169,"_33":34,"_35":170,"_24":25,"_154":-5,"_27":171},{"_43":156,"_32":157,"_30":158,"_148":-5,"_41":42,"_40":159,"_150":25,"_38":160,"_13":161,"_33":34,"_35":162,"_24":25,"_154":-5,"_27":163},{"_43":145,"_32":146,"_30":147,"_148":-5,"_41":42,"_40":149,"_150":25,"_38":151,"_13":152,"_33":34,"_35":153,"_24":25,"_154":-5,"_27":155},"75d7a80b-a949-4237-8a86-837c76efbc62","web.ts","d2e4e64e-9fd5-11f1-866a-1607ee4eb77e","parentId",94,"latest",["D",1787666163848],4,"import type { Hono } from \"npm:hono@4\";\n\nexport interface YouSearchHit {\n description?: string;\n page_age?: string;\n snippets?: string[];\n title?: string;\n url?: string;\n}\n\nexport interface YouSearchResponse {\n hits?: YouSearchHit[];\n results?: Array<{\n title: string;\n url: string;\n description: string;\n snippets?: string[];\n }>;\n}\n\n/**\n * Récupère les clés You.com configurées pour le triple fallback.\n */\nfunction getYouApiKeys(): string[] {\n const keys: string[] = [];\n const getEnv = (name: string): string | undefined => {\n if (typeof Deno !== \"undefined\" && Deno.env) {\n return Deno.env.get(name);\n }\n if (typeof process !== \"undefined\" && process.env) {\n return process.env[name];\n }\n };\n\n const candidateKeys = [\n getEnv(\"YOU_API_KEY\"),\n getEnv(\"YOU_API_KEY_1\"),\n getEnv(\"YOU_API_KEY_2\"),\n getEnv(\"YOU_API_KEY_3\"),\n getEnv(\"YDC_API_KEY\"),\n ];\n\n for (const k of candidateKeys) {\n if (k && k.trim() && !keys.includes(k.trim())) {\n keys.push(k.trim());\n }\n }\n\n return keys;\n}\n\n/**\n * Fallback Web Universel (Google News RSS, Bing News RSS, Wikipedia & DDG)\n */\nasync function fallbackWebSearch(\n query: string,\n count = 5,\n): Promise> {\n const results: Array<{ title: string; url: string; snippet: string }> = [];\n\n // 1. Essai Google News RSS (Ultra-rapide, mondial, temps réel, aucune clé requise)\n try {\n const rssUrl = `https://news.google.com/rss/search?q=${\n encodeURIComponent(query)\n }&hl=fr&gl=FR&ceid=FR:fr`;\n const res = await fetch(rssUrl, {\n headers: {\n \"User-Agent\":\n \"Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/122.0.0.0 Safari/537.36\",\n \"Accept\": \"application/rss+xml, text/xml, */*\",\n },\n });\n\n if (res.ok) {\n const xml = await res.text();\n const items = xml.split(\"\");\n for (let i = 1; i < items.length && results.length < count; i++) {\n const block = items[i].split(\"\")[0];\n const titleMatch = block.match(/([\\s\\S]*?)<\\/title>/i);\n const linkMatch = block.match(/<link>([\\s\\S]*?)<\\/link>/i) ||\n block.match(/<guid[^>]*>([\\s\\S]*?)<\\/guid>/i);\n const descMatch = block.match(\n /<description>([\\s\\S]*?)<\\/description>/i,\n );\n\n let title = titleMatch\n ? titleMatch[1].replace(/<!\\[CDATA\\[(.*?)\\]\\]>/gi, \"$1\").replace(\n /<[^>]+>/g,\n \"\",\n ).trim()\n : \"\";\n let link = linkMatch\n ? linkMatch[1].replace(/<!\\[CDATA\\[(.*?)\\]\\]>/gi, \"$1\").trim()\n : \"\";\n let snippet = descMatch\n ? descMatch[1].replace(/<!\\[CDATA\\[(.*?)\\]\\]>/gi, \"$1\").replace(\n /<[^>]+>/g,\n \"\",\n ).trim()\n : title;\n\n if (title && link) {\n results.push({\n title,\n url: link,\n snippet: snippet || title,\n });\n }\n }\n\n if (results.length > 0) return results;\n }\n } catch (err) {\n console.warn(\"[WebSearch] Fallback Google News RSS failed:\", err);\n }\n\n // 2. Essai Bing News RSS (Fallback de secours)\n try {\n const bingRssUrl = `https://www.bing.com/news/search?q=${\n encodeURIComponent(query)\n }&format=rss`;\n const res = await fetch(bingRssUrl, {\n headers: {\n \"User-Agent\":\n \"Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36\",\n \"Accept\": \"application/rss+xml, text/xml, */*\",\n },\n });\n\n if (res.ok) {\n const xml = await res.text();\n const items = xml.split(\"<item>\");\n for (let i = 1; i < items.length && results.length < count; i++) {\n const block = items[i].split(\"</item>\")[0];\n const titleMatch = block.match(/<title>([\\s\\S]*?)<\\/title>/i);\n const linkMatch = block.match(/<link>([\\s\\S]*?)<\\/link>/i);\n const descMatch = block.match(\n /<description>([\\s\\S]*?)<\\/description>/i,\n );\n\n const title = titleMatch\n ? titleMatch[1].replace(/<[^>]+>/g, \"\").trim()\n : \"\";\n const link = linkMatch ? linkMatch[1].trim() : \"\";\n const snippet = descMatch\n ? descMatch[1].replace(/<[^>]+>/g, \"\").trim()\n : title;\n\n if (title && link) {\n results.push({\n title,\n url: link,\n snippet: snippet || title,\n });\n }\n }\n\n if (results.length > 0) return results;\n }\n } catch (err) {\n console.warn(\"[WebSearch] Fallback Bing RSS failed:\", err);\n }\n\n // 3. Essai Wikipedia API\n try {\n const lang = /[éèàùçâêîôû]/i.test(query) ? \"fr\" : \"en\";\n const wikiUrl =\n `https://${lang}.wikipedia.org/w/api.php?action=opensearch&search=${\n encodeURIComponent(query)\n }&limit=${count}&namespace=0&format=json`;\n const res = await fetch(wikiUrl, {\n headers: {\n \"User-Agent\":\n \"mAI-WebSearch-Agent/1.0 (https://m-ai.fr; contact@m-ai.fr)\",\n },\n });\n if (res.ok) {\n const data = await res.json();\n const titles = data[1] || [];\n const descriptions = data[2] || [];\n const urls = data[3] || [];\n for (let i = 0; i < titles.length && results.length < count; i++) {\n if (urls[i]) {\n results.push({\n title: titles[i],\n url: urls[i],\n snippet: descriptions[i] || `Article Wikipedia sur ${titles[i]}`,\n });\n }\n }\n if (results.length > 0) return results;\n }\n } catch (err) {\n console.warn(\"[WebSearch] Fallback Wikipedia failed:\", err);\n }\n\n return results;\n}\n\n/**\n * Exécute une recherche Web via l'API You.com avec triple fallback automatique et fallback multi-sources.\n */\nexport async function executeWebSearch(\n query: string,\n count = 5,\n): Promise<{\n success: boolean;\n query: string;\n results: Array<{ title: string; url: string; snippet: string }>;\n provider: string;\n error?: string;\n}> {\n const trimmedQuery = (query || \"\").trim();\n if (!trimmedQuery) {\n return {\n error: \"La requête de recherche est vide.\",\n provider: \"you.com\",\n query: \"\",\n results: [],\n success: false,\n };\n }\n\n const keys = getYouApiKeys();\n let lastError: any = null;\n\n // 1. Tentative avec les clés You.com (POST https://ydc-index.io/v1/search conforme à l'API You.com)\n if (keys.length > 0) {\n const endpoints = [\n \"https://ydc-index.io/v1/search\",\n \"https://api.ydc-index.io/v1/search\",\n \"https://api.ydc-index.io/search\",\n ];\n\n for (let i = 0; i < keys.length; i++) {\n const key = keys[i];\n const keyLabel = `YOU_API_KEY_${i + 1}`;\n\n for (const endpointUrl of endpoints) {\n try {\n const res = await fetch(endpointUrl, {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n \"X-API-Key\": key,\n \"Accept\": \"application/json\",\n \"User-Agent\": \"mAI-WebSearch/1.0\",\n },\n body: JSON.stringify({\n query: trimmedQuery,\n count,\n }),\n });\n\n if (res.ok) {\n const data: any = await res.json().catch(() => null);\n if (data) {\n // Support complet des structures You.com v1 :\n // 1. data.results.web & data.results.news (Format officiel v1)\n // 2. data.results (Array direct)\n // 3. data.hits / data.web.results\n let rawHits: any[] = [];\n if (data.results && typeof data.results === \"object\") {\n if (Array.isArray(data.results)) {\n rawHits = data.results;\n } else {\n if (Array.isArray(data.results.web)) {\n rawHits.push(...data.results.web);\n }\n if (Array.isArray(data.results.news)) {\n rawHits.push(...data.results.news);\n }\n }\n } else if (Array.isArray(data.hits)) {\n rawHits = data.hits;\n } else if (Array.isArray(data.web?.results)) {\n rawHits = data.web.results;\n }\n\n const formattedResults = rawHits.map((hit: any) => {\n let snippet = \"\";\n if (hit.contents?.markdown) {\n snippet = hit.contents.markdown.slice(0, 300);\n } else if (\n hit.snippets && Array.isArray(hit.snippets) &&\n hit.snippets.length > 0\n ) {\n snippet = hit.snippets.join(\" ... \");\n } else {\n snippet = hit.description || hit.snippet || hit.text || \"\";\n }\n\n return {\n snippet: snippet.trim(),\n title: hit.title || hit.name || \"Sans titre\",\n url: hit.url || hit.link || \"\",\n };\n }).filter((item: any) => item.title && item.url);\n\n if (formattedResults.length > 0) {\n return {\n provider: \"you.com\",\n query: trimmedQuery,\n results: formattedResults,\n success: true,\n };\n }\n }\n }\n\n const status = res.status;\n const errBody = await res.text().catch(() => \"\");\n lastError = new Error(`HTTP ${status}: ${errBody}`);\n } catch (err: any) {\n lastError = err;\n }\n }\n }\n }\n\n // 2. Fallback automatique multi-moteurs (DDG Lite / Instant / Wikipedia)\n const fallbackResults = await fallbackWebSearch(trimmedQuery, count);\n if (fallbackResults.length > 0) {\n return {\n provider: \"duckduckgo (fallback)\",\n query: trimmedQuery,\n results: fallbackResults,\n success: true,\n };\n }\n\n return {\n error: keys.length === 0\n ? \"Aucune clé You.com configurée et les services de fallback sont temporairement inaccessibles.\"\n : `Échec de la recherche (${lastError?.message || \"Erreur\"}).`,\n provider: \"you.com\",\n query: trimmedQuery,\n results: [],\n success: false,\n };\n}\n\n/**\n * Définition standard de l'outil web_search pour les IA compatibles Tool Calling.\n */\nexport const WEB_SEARCH_TOOL = {\n function: {\n description:\n \"Recherche sur le Web des informations récentes et actualisées en temps réel via You.com.\",\n name: \"web_search\",\n parameters: {\n properties: {\n query: {\n description: \"La requête de recherche textuelle complète et précise.\",\n type: \"string\",\n },\n },\n required: [\"query\"],\n type: \"object\",\n },\n },\n type: \"function\" as const,\n};\n\n/**\n * Vérifie si la recherche web doit être activée ou désactivée sur un appel API.\n */\nexport function isWebSearchEnabled(body: any, reqHeaders?: Headers): boolean {\n if (body && (body.web_search === false || body.enable_web_search === false)) {\n return false;\n }\n if (reqHeaders) {\n const headerVal = reqHeaders.get(\"x-web-search\") ||\n reqHeaders.get(\"X-Web-Search\");\n if (headerVal && headerVal.toLowerCase() === \"false\") {\n return false;\n }\n const disableHeader = reqHeaders.get(\"x-disable-web-search\") ||\n reqHeaders.get(\"X-Disable-Web-Search\");\n if (\n disableHeader &&\n (disableHeader.toLowerCase() === \"true\" || disableHeader === \"1\")\n ) {\n return false;\n }\n }\n return true;\n}\n\n/**\n * Enregistrement des routes de recherche Web dans Hono.\n */\nexport function registerWebRoutes(app: Hono) {\n // POST /v1/web/search\n app.post(\"/v1/web/search\", async (c) => {\n try {\n const body = await c.req.json().catch(() => ({}));\n const query = body.query || body.q;\n const count = typeof body.count === \"number\" ? body.count : 5;\n\n if (!query || typeof query !== \"string\") {\n return c.json({ error: \"Le paramètre 'query' est obligatoire.\" }, 400);\n }\n\n const searchResult = await executeWebSearch(query, count);\n return c.json(searchResult, 200);\n } catch (err: any) {\n return c.json({\n error: \"Erreur serveur lors de la recherche Web.\",\n details: err?.message,\n }, 500);\n }\n });\n\n // GET /v1/web/search\n app.get(\"/v1/web/search\", async (c) => {\n try {\n const query = c.req.query(\"q\") || c.req.query(\"query\");\n const countParam = c.req.query(\"count\");\n const count = countParam ? Number.parseInt(countParam, 10) : 5;\n\n if (!query) {\n return c.json({ error: \"Paramètre 'q' ou 'query' manquant.\" }, 400);\n }\n\n const searchResult = await executeWebSearch(\n query,\n isNaN(count) ? 5 : count,\n );\n return c.json(searchResult, 200);\n } catch (err: any) {\n return c.json({\n error: \"Erreur serveur lors de la recherche Web.\",\n details: err?.message,\n }, 500);\n }\n });\n}","label",[146],"a6a735b8-d182-4f9d-b606-7a38486fbc7b","storage.ts","e973306e-9c6a-11f1-8111-1607ee4eb77e",117,["D",1787908549794],7,"import type { Hono } from \"npm:hono@4\";\nimport {\n extractToken,\n getDb,\n STORAGE_LIMITS_BYTES,\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 cleanValue(val: string): string {\n let cleaned = (val || \"\").trim();\n if (\n (cleaned.startsWith('\"') && cleaned.endsWith('\"')) ||\n (cleaned.startsWith(\"'\") && cleaned.endsWith(\"'\"))\n ) {\n cleaned = cleaned.slice(1, -1).trim();\n }\n return cleaned;\n}\n\nfunction cleanUrl(url: string, removeDefaultPort = true): string {\n let cleaned = cleanValue(url);\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 * Conservé pour compatibilité descendante.\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 * Retourne le nombre total de nœuds de stockage actuellement détectés et configurés.\n */\nexport function getTotalStorageNodesCount(): number {\n return getStorageNodes().length;\n}\n\n/**\n * Recherche une variable d'environnement pour un index de bucket donné i.\n * Supporte n'importe quel préfixe ou convention tant que la variable porte le numéro i.\n */\nfunction getEnvForNode(\n directKeys: string[],\n regex: RegExp,\n env: Record<string, string>,\n): string | undefined {\n for (const k of directKeys) {\n const val = Deno.env.get(k);\n if (val !== undefined && val.trim() !== \"\") {\n return cleanValue(val);\n }\n }\n\n for (const [k, v] of Object.entries(env)) {\n if (regex.test(k) && v && v.trim() !== \"\") {\n return cleanValue(v);\n }\n }\n\n return undefined;\n}\n\nfunction getBucketName(\n i: number,\n env: Record<string, string>,\n): string | undefined {\n return getEnvForNode(\n [\n `S3_BUCKET_${i}`,\n `S3_BUCKET${i}`,\n `Z1_BUCKET_${i}`,\n `Z1_BUCKET${i}`,\n `R2_BUCKET_${i}`,\n `R2_BUCKET${i}`,\n `STORAGE_BUCKET_${i}`,\n `STORAGE_BUCKET${i}`,\n `BUCKET_${i}`,\n `BUCKET${i}`,\n `S3_BUCKET_NAME_${i}`,\n `S3_BUCKET_NAME${i}`,\n `BUCKET_NAME_${i}`,\n `BUCKET_NAME${i}`,\n `S3_NAME_${i}`,\n `NAME_${i}`,\n ],\n new RegExp(\n `(^|_|-)(?:S3_|Z1_|R2_|STORAGE_)?BUCKET(?:_NAME)?(_|-)?${i}$`,\n \"i\",\n ),\n env,\n );\n}\n\nfunction getAccessKey(\n i: number,\n env: Record<string, string>,\n fallback: string,\n): string {\n return (\n getEnvForNode(\n [\n `S3_ACCESS_KEY_ID_${i}`,\n `S3_ACCESS_KEY_ID${i}`,\n `Z1_ACCESS_KEY_ID_${i}`,\n `Z1_ACCESS_KEY_ID${i}`,\n `R2_ACCESS_KEY_ID_${i}`,\n `R2_ACCESS_KEY_ID${i}`,\n `ACCESS_KEY_ID_${i}`,\n `ACCESS_KEY_ID${i}`,\n `S3_ACCESS_KEY_${i}`,\n `ACCESS_KEY_${i}`,\n `S3_KEY_ID_${i}`,\n `KEY_ID_${i}`,\n `S3_KEY_${i}`,\n `KEY_${i}`,\n ],\n new RegExp(\n `(^|_|-)(?:S3_|Z1_|R2_|STORAGE_)?(?:ACCESS_KEY(?:_ID)?|KEY_ID|KEY)(_|-)?${i}$`,\n \"i\",\n ),\n env,\n ) || fallback\n );\n}\n\nfunction getSecretKey(\n i: number,\n env: Record<string, string>,\n fallback: string,\n): string {\n return (\n getEnvForNode(\n [\n `S3_SECRET_ACCESS_KEY_${i}`,\n `S3_SECRET_ACCESS_KEY${i}`,\n `Z1_SECRET_ACCESS_KEY_${i}`,\n `Z1_SECRET_ACCESS_KEY${i}`,\n `R2_SECRET_ACCESS_KEY_${i}`,\n `R2_SECRET_ACCESS_KEY${i}`,\n `SECRET_ACCESS_KEY_${i}`,\n `SECRET_ACCESS_KEY${i}`,\n `S3_SECRET_KEY_${i}`,\n `SECRET_KEY_${i}`,\n `S3_SECRET_${i}`,\n `SECRET_${i}`,\n ],\n new RegExp(\n `(^|_|-)(?:S3_|Z1_|R2_|STORAGE_)?(?:SECRET_ACCESS_KEY|SECRET_KEY|SECRET)(_|-)?${i}$`,\n \"i\",\n ),\n env,\n ) || fallback\n );\n}\n\nfunction getEndpoint(\n i: number,\n env: Record<string, string>,\n fallback: string,\n): string {\n const ep = getEnvForNode(\n [\n `S3_ENDPOINT_${i}`,\n `S3_ENDPOINT${i}`,\n `Z1_ENDPOINT_${i}`,\n `Z1_ENDPOINT${i}`,\n `R2_ENDPOINT_${i}`,\n `R2_ENDPOINT${i}`,\n `ENDPOINT_${i}`,\n `ENDPOINT${i}`,\n `STORAGE_ENDPOINT_${i}`,\n `STORAGE_ENDPOINT${i}`,\n ],\n new RegExp(\n `(^|_|-)(?:S3_|Z1_|R2_|STORAGE_)?(?:ENDPOINT|STORAGE_URL)(_|-)?${i}$`,\n \"i\",\n ),\n env,\n );\n return ep ? cleanUrl(ep) : fallback;\n}\n\nfunction getRegion(\n i: number,\n env: Record<string, string>,\n fallback: string,\n): string {\n return (\n getEnvForNode(\n [\n `S3_REGION_${i}`,\n `S3_REGION${i}`,\n `Z1_REGION_${i}`,\n `Z1_REGION${i}`,\n `R2_REGION_${i}`,\n `R2_REGION${i}`,\n `REGION_${i}`,\n `REGION${i}`,\n ],\n new RegExp(`(^|_|-)(?:S3_|Z1_|R2_|STORAGE_)?REGION(_|-)?${i}$`, \"i\"),\n env,\n ) || fallback\n );\n}\n\nfunction getPublicUrl(\n i: number,\n env: Record<string, string>,\n bucket: string,\n endpoint: string,\n basePublicUrl?: string,\n): string {\n const direct = getEnvForNode(\n [\n `S3_PUBLIC_URL_${i}`,\n `S3_PUBLIC_URL${i}`,\n `Z1_PUBLIC_URL_${i}`,\n `Z1_PUBLIC_URL${i}`,\n `R2_PUBLIC_URL_${i}`,\n `R2_PUBLIC_URL${i}`,\n `PUBLIC_URL_${i}`,\n `PUBLIC_URL${i}`,\n ],\n new RegExp(`(^|_|-)(?:S3_|Z1_|R2_|STORAGE_)?PUBLIC_URL(_|-)?${i}$`, \"i\"),\n env,\n );\n if (direct) return cleanUrl(direct);\n\n if (basePublicUrl && basePublicUrl.trim()) {\n return `${cleanUrl(basePublicUrl)}/${bucket}`;\n }\n\n return `${endpoint}/${bucket}`;\n}\n\n/**\n * Récupère la liste dynamique des nœuds de stockage Z1 Storage / S3 configurés.\n * Supporte un nombre illimité de buckets de n'importe quel nom, tant qu'ils ont\n * leurs valeurs définies et leur numéro après chaque variable (ex: S3_BUCKET_1..N, S3_ACCESS_KEY_ID_1..N, etc.).\n * Supporte également une liste de buckets séparés par des virgules (S3_BUCKETS / Z1_BUCKETS / BUCKETS).\n */\nexport function getStorageNodes(): StorageNode[] {\n const nodes: StorageNode[] = [];\n\n let env: Record<string, string> = {};\n try {\n env = Deno.env.toObject();\n } catch {\n env = {};\n }\n\n const baseAccessKey = cleanValue(\n Deno.env.get(\"S3_ACCESS_KEY_ID\") ||\n Deno.env.get(\"Z1_ACCESS_KEY_ID\") ||\n Deno.env.get(\"R2_ACCESS_KEY_ID\") ||\n Deno.env.get(\"ACCESS_KEY_ID\") ||\n \"\",\n );\n const baseSecretKey = cleanValue(\n Deno.env.get(\"S3_SECRET_ACCESS_KEY\") ||\n Deno.env.get(\"Z1_SECRET_ACCESS_KEY\") ||\n Deno.env.get(\"R2_SECRET_ACCESS_KEY\") ||\n Deno.env.get(\"SECRET_ACCESS_KEY\") ||\n \"\",\n );\n const baseRawEndpoint = cleanValue(\n Deno.env.get(\"S3_ENDPOINT\") ||\n Deno.env.get(\"Z1_ENDPOINT\") ||\n Deno.env.get(\"R2_ENDPOINT\") ||\n Deno.env.get(\"ENDPOINT\") ||\n \"https://s3.z1storage.com\",\n );\n const baseEndpoint = cleanUrl(baseRawEndpoint);\n const baseRegion = cleanValue(\n Deno.env.get(\"S3_REGION\") ||\n Deno.env.get(\"Z1_REGION\") ||\n Deno.env.get(\"R2_REGION\") ||\n Deno.env.get(\"REGION\") ||\n \"auto\",\n );\n const baseBucket = cleanValue(\n Deno.env.get(\"S3_BUCKET\") ||\n Deno.env.get(\"Z1_BUCKET\") ||\n Deno.env.get(\"R2_BUCKET\") ||\n Deno.env.get(\"BUCKET\") ||\n \"\",\n );\n const basePublicUrl = Deno.env.get(\"S3_PUBLIC_URL\") ||\n Deno.env.get(\"Z1_PUBLIC_URL\") ||\n Deno.env.get(\"R2_PUBLIC_URL\") ||\n Deno.env.get(\"PUBLIC_URL\");\n\n // Clés par défaut héritables si non spécifiées pour un numéro donné\n const defaultAccessKey = baseAccessKey ||\n cleanValue(\n Deno.env.get(\"S3_ACCESS_KEY_ID_1\") ||\n Deno.env.get(\"Z1_ACCESS_KEY_ID_1\") || \"\",\n );\n const defaultSecretKey = baseSecretKey ||\n cleanValue(\n Deno.env.get(\"S3_SECRET_ACCESS_KEY_1\") ||\n Deno.env.get(\"Z1_SECRET_ACCESS_KEY_1\") || \"\",\n );\n\n // 1. Détection de tous les numéros de buckets configurés\n const detectedIds = new Set<number>();\n\n // Scanner toutes les variables d'environnement pour extraire les numéros\n for (const key of Object.keys(env)) {\n const match = key.match(\n /(?:BUCKET|ACCESS_KEY|SECRET|ENDPOINT|REGION|PUBLIC_URL|STORAGE).*?_?(\\d+)$/i,\n );\n if (match) {\n const num = parseInt(match[1], 10);\n if (num > 0 && !isNaN(num)) {\n detectedIds.add(num);\n }\n }\n }\n\n // Scan séquentiel de sécurité 1..N pour couvrir les cas où toObject() serait partiel\n let seq = 1;\n let consecutiveMisses = 0;\n const maxDetected = detectedIds.size > 0 ? Math.max(...detectedIds) : 0;\n while (consecutiveMisses < 10 && seq <= Math.max(maxDetected + 5, 20)) {\n const hasBucket = getBucketName(seq, env);\n const hasKey = Deno.env.get(`S3_ACCESS_KEY_ID_${seq}`) ||\n Deno.env.get(`S3_ACCESS_KEY_ID${seq}`) ||\n Deno.env.get(`ACCESS_KEY_ID_${seq}`);\n\n if (hasBucket || hasKey) {\n detectedIds.add(seq);\n consecutiveMisses = 0;\n } else if (seq > maxDetected) {\n consecutiveMisses++;\n }\n seq++;\n }\n\n // 2. Construction des nœuds pour chaque ID détecté\n const sortedIds = Array.from(detectedIds).sort((a, b) => a - b);\n for (const id of sortedIds) {\n const bucket = getBucketName(id, env);\n if (!bucket) continue;\n\n const accessKeyId = getAccessKey(id, env, defaultAccessKey);\n const secretAccessKey = getSecretKey(id, env, defaultSecretKey);\n const endpoint = getEndpoint(id, env, baseEndpoint);\n const region = getRegion(id, env, baseRegion);\n const publicUrl = getPublicUrl(id, env, bucket, endpoint, basePublicUrl);\n\n if (bucket && accessKeyId && secretAccessKey) {\n nodes.push({\n id,\n endpoint,\n region,\n accessKeyId,\n secretAccessKey,\n bucket,\n publicUrl,\n });\n }\n }\n\n // 3. Si aucun bucket avec numéro n'a été trouvé, vérifier si une liste séparée par des virgules est fournie\n if (nodes.length === 0) {\n const bucketsList = Deno.env.get(\"S3_BUCKETS\") ||\n Deno.env.get(\"Z1_BUCKETS\") ||\n Deno.env.get(\"BUCKETS\");\n if (bucketsList) {\n const bucketNames = bucketsList\n .split(\",\")\n .map((b) => cleanValue(b))\n .filter(Boolean);\n\n bucketNames.forEach((bucket, idx) => {\n const id = idx + 1;\n const publicUrl = basePublicUrl\n ? `${cleanUrl(basePublicUrl)}/${bucket}`\n : `${baseEndpoint}/${bucket}`;\n\n if (defaultAccessKey && defaultSecretKey) {\n nodes.push({\n id,\n endpoint: baseEndpoint,\n region: baseRegion,\n accessKeyId: defaultAccessKey,\n secretAccessKey: defaultSecretKey,\n bucket,\n publicUrl,\n });\n }\n });\n }\n }\n\n // 4. Fallback si aucun bucket configuré (évite une liste vide au démarrage)\n if (nodes.length === 0) {\n const fallbackBucket = baseBucket ||\n (DEFAULT_Z1_FALLBACK_BUCKETS[0] ?? \"mai-storage-1\");\n const fallbackEndpoint = baseEndpoint;\n const fallbackPublic = basePublicUrl\n ? `${cleanUrl(basePublicUrl)}/${fallbackBucket}`\n : `${fallbackEndpoint}/${fallbackBucket}`;\n\n nodes.push({\n id: 1,\n endpoint: fallbackEndpoint,\n region: baseRegion,\n accessKeyId: defaultAccessKey,\n secretAccessKey: defaultSecretKey,\n bucket: fallbackBucket,\n publicUrl: fallbackPublic,\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 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\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\"];\n\n if (!(file instanceof File)) {\n return c.json({ error: \"Fichier invalide ou non fourni.\" }, 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({ error: \"Erreur lors de l'upload de l'image.\" }, 500);\n }\n\n const publicUrl = uploadResult.publicUrl;\n\n const sql = getDb();\n await sql`UPDATE users SET avatar_url = ${publicUrl} WHERE id = ${userId}`;\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 = 10 * 1024 * 1024;\n if (file.size > MAX_FILE_SIZE) {\n return c.json({ error: \"Fichier trop volumineux (max 10 MB).\" }, 413);\n }\n if (file.size === 0) {\n return c.json({ error: \"Fichier vide.\" }, 400);\n }\n const ALLOWED = [\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 isAllowed = ALLOWED.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 && !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({ error: \"Erreur lors de l'upload vers S3.\" }, 500);\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 rawTier2 = 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 = STORAGE_LIMITS_BYTES[tier] ||\n STORAGE_LIMITS_BYTES[tier.toLowerCase()] ||\n STORAGE_LIMITS_BYTES[\n tier.charAt(0).toUpperCase() + tier.slice(1).toLowerCase()\n ] ||\n STORAGE_LIMITS_BYTES[\"Free\"];\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 = STORAGE_LIMITS_BYTES[tier] ||\n STORAGE_LIMITS_BYTES[tier.toLowerCase()] ||\n STORAGE_LIMITS_BYTES[\n tier.charAt(0).toUpperCase() + tier.slice(1).toLowerCase()\n ] ||\n STORAGE_LIMITS_BYTES[\"Free\"];\n\n if (bytesUsed + fileSize > bytesLimit) {\n const limitMB = Math.round(bytesLimit / (1024 * 1024));\n const usedMB = Math.round(bytesUsed / (1024 * 1024));\n return c.json(\n {\n bytes_limit: bytesLimit,\n bytes_used: bytesUsed,\n error:\n `Quota de stockage dépassé. Vous utilisez ${usedMB} MB sur ${limitMB} MB (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 dynamique de 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}",[157],"ebf8909c-d809-41fa-a9c8-1d1bfaee0080","projects.ts","e972f7ac-9c6a-11f1-8111-1607ee4eb77e",84,["D",1787587613987],3,"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: \"Alpha\",\n name: \"Web\",\n project_id: \"web\",\n repository: \"https://github.com/mDevsLabs/Web\",\n status: \"alpha\",\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: \"Bêta\",\n name: \"Pulse\",\n project_id: \"pulse\",\n repository: \"https://github.com/mDevsLabs/Pulse\",\n status: \"beta\",\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: \"Bêta\",\n name: \"CLI\",\n project_id: \"cli\",\n repository: \"https://github.com/mDevsLabs/CLI\",\n status: \"beta\",\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: \"Alpha\",\n name: \"Coder\",\n project_id: \"coder\",\n repository: \"https://github.com/mDevsLabs/Coder\",\n status: \"alpha\",\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: \"Productivity\",\n created_at: \"2026-08-12T00:00:00.000Z\",\n description: \"Création de documents et présentations assistée par mAI.\",\n features: [\n \"Génération de documents\",\n \"Présentations interactives\",\n \"Export multi-format\",\n ],\n id: \"proj_office\",\n is_public: true,\n label: \"Archivé\",\n name: \"Office\",\n project_id: \"office\",\n repository: \"https://github.com/mDevsLabs/Office\",\n status: \"archived\",\n version: \"0.1.0\",\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<string, any> = {\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 office: {\n category: \"Productivity\",\n created_at: \"2026-08-12T00:00:00.000Z\",\n description: \"Création de documents et présentations avec mAI.\",\n is_public: true,\n label: \"Archivé\",\n name: \"Office\",\n project_id: \"office\",\n repository: \"https://github.com/mDevsLabs/Office\",\n status: \"archived\",\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}",[165],"5626c5b8-7df5-49e4-a4ff-ecdbeafc3887","models.ts","e972ab30-9c6a-11f1-8111-1607ee4eb77e",112,["D",1787759873515],22,"import type { Hono } from \"npm:hono@4\";\nimport {\n extractToken,\n getDb,\n getTierSpeechLimit,\n getWeekData,\n TIER_LIMITS,\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 // GET /usage\n app.get(\"/usage\", 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 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}::integer 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 limit = TIER_LIMITS[userTier] || TIER_LIMITS[\"Free\"];\n const speechLimit = getTierSpeechLimit(userTier);\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 // POST /log-usage\n app.post(\"/log-usage\", 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 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 limit = TIER_LIMITS[tier] || TIER_LIMITS[\"Free\"];\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 // ─────────────────────────────────────────────\n // GET /v1/models, /models & /v1beta/models\n // ─────────────────────────────────────────────\n const handleGetModels = async (c: any) => {\n const userPlan = c.get(\"userPlan\");\n const planStr = String(userPlan || \"Free\")\n .toLowerCase()\n .trim();\n const isPaidPlan = [\"plus\", \"pro\", \"max\"].includes(planStr);\n const shouldFilterFreeOnly = !isPaidPlan;\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 return c.json({ data: filtered, object: \"list\" });\n } catch (_err) {\n let fallback = [\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<string, any>;\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 planStr = String(userPlan || \"Free\")\n .toLowerCase()\n .trim();\n const isPaidPlan = [\"plus\", \"pro\", \"max\"].includes(planStr);\n const isFreePlan = !isPaidPlan;\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 limit = TIER_LIMITS[String(userPlan || \"Free\")] ||\n TIER_LIMITS[\"Free\"];\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<string, any>;\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 \"Access-Control-Allow-Origin\": \"*\",\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<string, any>;\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 planStr = String(userPlan || \"Free\")\n .toLowerCase()\n .trim();\n const isPaidPlan = [\"plus\", \"pro\", \"max\"].includes(planStr);\n const isFreePlan = !isPaidPlan;\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 limit = TIER_LIMITS[String(userPlan || \"Free\")] ||\n TIER_LIMITS[\"Free\"];\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<string, any>;\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 \"Access-Control-Allow-Origin\": \"*\",\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<string, any> = {};\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 planStr = String(userPlan || \"Free\")\n .toLowerCase()\n .trim();\n const isPaidPlan = [\"plus\", \"pro\", \"max\"].includes(planStr);\n const isFreePlan = !isPaidPlan;\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 limit = TIER_LIMITS[String(userPlan || \"Free\")] ||\n TIER_LIMITS[\"Free\"];\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<string, any>;\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 \"Access-Control-Allow-Origin\": \"*\",\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}",[173],"8de43cd6-f41f-4ac6-8c68-de9b06512096","main.ts",88,["D",1787660803355],42,"http","/**\n * mAI — Val Town HTTP Proxy & Auth Backend\n * 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 { registerStorageRoutes } from \"./storage.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\nconst ALLOWED_ORIGINS = [\n \"https://mai-officiel.vercel.app\",\n \"https://mai-devs.vercel.app\",\n \"https://mai.val.run\",\n \"https://mdevslabs.github.io\",\n \"https://m-ai.fr\",\n \"https://www.m-ai.fr\",\n \"http://localhost:3000\",\n \"http://localhost:3001\",\n];\n\napp.use(\n \"*\",\n cors({\n allowHeaders: [\n \"Content-Type\",\n \"Authorization\",\n \"x-user-id\",\n \"x-api-key\",\n \"X-User-Id\",\n \"X-API-Key\",\n \"x-web-search\",\n \"X-Web-Search\",\n \"x-disable-web-search\",\n \"X-Disable-Web-Search\",\n \"x-goog-api-key\",\n \"X-Goog-Api-Key\",\n \"anthropic-version\",\n \"anthropic-beta\",\n ],\n allowMethods: [\"GET\", \"POST\", \"PUT\", \"DELETE\", \"PATCH\", \"OPTIONS\"],\n exposeHeaders: [\"Content-Type\", \"Authorization\", \"x-user-id\"],\n maxAge: 86_400,\n origin: (origin) => {\n if (!origin) return \"*\"; // allow curl / mobile\n if (ALLOWED_ORIGINS.includes(origin)) return origin;\n // Allow vercel preview deployments\n if (origin.endsWith(\".vercel.app\")) return origin;\n return ALLOWED_ORIGINS[0];\n },\n credentials: true,\n }),\n);\n\n// ─────────────────────────────────────────────\n// ROUTE PAR DÉFAUT (Pour éviter le 404 en preview)\n// ─────────────────────────────────────────────\napp.get(\"/\", (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);\n\nexport default app.fetch;",[181],"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;",[189],"ff899dbf-afe5-46ac-be7e-040054c9cd65","images.ts","d2e42ca4-9fd5-11f1-866a-1607ee4eb77e",115,["D",1787812770684],"import type { Hono } from \"npm:hono@4\";\nimport {\n extractToken,\n getDb,\n getTierDailyImageLimit,\n getTierImageRequestCost,\n verifyToken,\n} from \"./config.ts\";\n\nexport interface ImageModelItem {\n capabilities?: {\n async_task?: boolean;\n image_to_image?: boolean;\n inpainting?: boolean;\n text_to_image?: boolean;\n upscaling?: boolean;\n variation?: boolean;\n };\n created: number;\n description: string;\n endpoints?: string[];\n features: string[];\n form:\n | \"openai-standard\"\n | \"midjourney-pipeline\"\n | \"image-edit\"\n | \"image-upscale\";\n id: string;\n name: string;\n object: \"model\";\n owned_by: string;\n parent?: string | null;\n permission?: Array<{\n allow_create_engine: boolean;\n allow_fine_tuning: boolean;\n allow_logprobs: boolean;\n allow_sampling: boolean;\n allow_search_indices: boolean;\n allow_view: boolean;\n created: number;\n group: string | null;\n id: string;\n is_blocking: boolean;\n object: \"model_permission\";\n organization: string;\n }>;\n root?: string;\n}\n\nexport function getCometApiKey(): string {\n if (typeof Deno !== \"undefined\" && Deno.env) {\n return Deno.env.get(\"COMET_API_KEY\") || \"\";\n }\n if (typeof process !== \"undefined\" && process.env) {\n return process.env.COMET_API_KEY || \"\";\n }\n return \"\";\n}\n\nexport function normalizeImageSrc(url?: string | null): string {\n if (!url || typeof url !== \"string\") {\n return \"\";\n }\n const clean = url.trim().replace(/^[\"']|[\"']$/g, \"\");\n if (!clean) {\n return \"\";\n }\n\n if (\n clean.startsWith(\"http://\") ||\n clean.startsWith(\"https://\") ||\n clean.startsWith(\"data:\") ||\n clean.startsWith(\"blob:\") ||\n clean.startsWith(\"/\")\n ) {\n return clean;\n }\n\n let mime = \"image/png\";\n if (clean.startsWith(\"/9j/\")) {\n mime = \"image/jpeg\";\n } else if (clean.startsWith(\"R0lGOD\")) {\n mime = \"image/gif\";\n } else if (clean.startsWith(\"UklGR\")) {\n mime = \"image/webp\";\n } else if (clean.startsWith(\"PHN2Zy\") || clean.startsWith(\"PD94bWw\")) {\n mime = \"image/svg+xml\";\n }\n\n return `data:${mime};base64,${clean}`;\n}\n\n/**\n * Cache mémoire pour les modèles CometAPI (TTL = 60 secondes)\n */\nlet cachedCometImageModels: ImageModelItem[] = [];\nlet lastCometFetchTime = 0;\nconst CACHE_TTL_MS = 60_000;\n\n/**\n * Modèles de repli de haute qualité en cas de défaillance réseau temporaire de CometAPI\n */\nconst FALLBACK_IMAGE_MODELS: ImageModelItem[] = [\n {\n capabilities: {\n async_task: true,\n image_to_image: false,\n inpainting: false,\n text_to_image: true,\n },\n created: 1722470400,\n description:\n \"Modèle ultra-rapide en 4 étapes par Black Forest Labs (Text-to-Image).\",\n endpoints: [\"/v1/images/generations\"],\n features: [\"text-to-image\"],\n form: \"openai-standard\",\n id: \"black-forest-labs/flux-schnell\",\n name: \"FLUX.1 Schnell\",\n object: \"model\",\n owned_by: \"black-forest-labs\",\n },\n {\n capabilities: {\n async_task: true,\n image_to_image: true,\n inpainting: true,\n text_to_image: true,\n },\n created: 1722470400,\n description:\n \"Modèle phare de synthèse photoréaliste et artistique par Black Forest Labs (Text-to-Image / Image-to-Image).\",\n endpoints: [\"/v1/images/generations\", \"/v1/images/edits\"],\n features: [\"text-to-image\", \"image-to-image\"],\n form: \"openai-standard\",\n id: \"black-forest-labs/flux-dev\",\n name: \"FLUX.1 Dev\",\n object: \"model\",\n owned_by: \"black-forest-labs\",\n },\n {\n capabilities: {\n async_task: true,\n image_to_image: false,\n inpainting: false,\n text_to_image: true,\n },\n created: 1727827200,\n description:\n \"Sommet de la qualité visuelle, cohérence typographique et détails avancés par Black Forest Labs.\",\n endpoints: [\"/v1/images/generations\"],\n features: [\"text-to-image\"],\n form: \"openai-standard\",\n id: \"black-forest-labs/flux-pro\",\n name: \"FLUX 1.1 Pro\",\n object: \"model\",\n owned_by: \"black-forest-labs\",\n },\n {\n capabilities: {\n async_task: true,\n image_to_image: false,\n inpainting: false,\n text_to_image: true,\n },\n created: 1730419200,\n description:\n \"Version Ultra haute résolution (jusqu'à 4K) avec photoréalisme extrême et détails de peau par Black Forest Labs.\",\n endpoints: [\"/v1/images/generations\"],\n features: [\"text-to-image\"],\n form: \"openai-standard\",\n id: \"black-forest-labs/flux-1.1-pro-ultra\",\n name: \"FLUX 1.1 Pro Ultra\",\n object: \"model\",\n owned_by: \"black-forest-labs\",\n },\n {\n capabilities: {\n async_task: true,\n image_to_image: true,\n inpainting: true,\n text_to_image: true,\n },\n created: 1729641600,\n description:\n \"Modèle phare de 8 milliards de paramètres de Stability AI pour une variété stylistique maximale et une typographie nette.\",\n endpoints: [\"/v1/images/generations\", \"/v1/images/edits\"],\n features: [\"text-to-image\", \"image-to-image\"],\n form: \"openai-standard\",\n id: \"stabilityai/stable-diffusion-3.5-large\",\n name: \"Stable Diffusion 3.5 Large\",\n object: \"model\",\n owned_by: \"stabilityai\",\n },\n {\n capabilities: {\n async_task: true,\n image_to_image: false,\n inpainting: false,\n text_to_image: true,\n },\n created: 1729641600,\n description:\n \"Version accélérée en 4 étapes de Stable Diffusion 3.5 Large par Stability AI.\",\n endpoints: [\"/v1/images/generations\"],\n features: [\"text-to-image\"],\n form: \"openai-standard\",\n id: \"stabilityai/stable-diffusion-3.5-large-turbo\",\n name: \"Stable Diffusion 3.5 Large Turbo\",\n object: \"model\",\n owned_by: \"stabilityai\",\n },\n {\n capabilities: {\n async_task: true,\n image_to_image: true,\n inpainting: true,\n text_to_image: true,\n },\n created: 1690848000,\n description:\n \"Modèle SDXL 1.0 haute résolution de Stability AI pour la création artistique et le rendu réaliste.\",\n endpoints: [\"/v1/images/generations\", \"/v1/images/edits\"],\n features: [\"text-to-image\", \"image-to-image\"],\n form: \"openai-standard\",\n id: \"stabilityai/sdxl\",\n name: \"Stable Diffusion XL 1.0\",\n object: \"model\",\n owned_by: \"stabilityai\",\n },\n {\n capabilities: {\n async_task: true,\n image_to_image: true,\n inpainting: true,\n text_to_image: true,\n upscaling: true,\n variation: true,\n },\n created: 1718064000,\n description:\n \"Génération stylisée haut de gamme avec esthétique cinématique et compréhension sémantique de pointe via Midjourney v6.\",\n endpoints: [\n \"/v1/images/generations\",\n \"/mj/submit/imagine\",\n \"/mj/submit/action\",\n \"/mj/task/:id/fetch\",\n ],\n features: [\"text-to-image\", \"image-to-image\", \"upscale\", \"variation\"],\n form: \"midjourney-pipeline\",\n id: \"midjourney/v6\",\n name: \"Midjourney v6\",\n object: \"model\",\n owned_by: \"midjourney\",\n },\n {\n capabilities: {\n async_task: true,\n image_to_image: true,\n inpainting: true,\n text_to_image: true,\n upscaling: true,\n variation: true,\n },\n created: 1722384000,\n description:\n \"Dernière itération du moteur Midjourney v6.1 avec cohérence accrue des mains, textures et détails fins.\",\n endpoints: [\n \"/v1/images/generations\",\n \"/mj/submit/imagine\",\n \"/mj/submit/action\",\n \"/mj/task/:id/fetch\",\n ],\n features: [\"text-to-image\", \"image-to-image\", \"upscale\", \"variation\"],\n form: \"midjourney-pipeline\",\n id: \"midjourney/v6.1\",\n name: \"Midjourney v6.1\",\n object: \"model\",\n owned_by: \"midjourney\",\n },\n {\n capabilities: {\n async_task: true,\n image_to_image: true,\n inpainting: false,\n text_to_image: true,\n },\n created: 1730419200,\n description:\n \"Génération vectorielle et matricielle spécialisée dans les logos, icônes, illustrations et design graphique.\",\n endpoints: [\"/v1/images/generations\"],\n features: [\"text-to-image\", \"image-to-image\"],\n form: \"openai-standard\",\n id: \"recraft-ai/recraft-v3\",\n name: \"Recraft V3\",\n object: \"model\",\n owned_by: \"recraft-ai\",\n },\n {\n capabilities: {\n async_task: true,\n image_to_image: false,\n inpainting: false,\n text_to_image: true,\n },\n created: 1724284800,\n description:\n \"Modèle phare de rendu de texte dans l'image et composition graphique par Ideogram AI.\",\n endpoints: [\"/v1/images/generations\"],\n features: [\"text-to-image\"],\n form: \"openai-standard\",\n id: \"ideogram-ai/ideogram-v2\",\n name: \"Ideogram V2\",\n object: \"model\",\n owned_by: \"ideogram-ai\",\n },\n {\n capabilities: {\n async_task: true,\n image_to_image: false,\n inpainting: false,\n text_to_image: true,\n },\n created: 1724284800,\n description:\n \"Version ultra-rapide d'Ideogram V2 optimisée pour les flux de production en temps réel.\",\n endpoints: [\"/v1/images/generations\"],\n features: [\"text-to-image\"],\n form: \"openai-standard\",\n id: \"ideogram-ai/ideogram-v2-turbo\",\n name: \"Ideogram V2 Turbo\",\n object: \"model\",\n owned_by: \"ideogram-ai\",\n },\n {\n capabilities: {\n async_task: true,\n image_to_image: false,\n inpainting: false,\n text_to_image: true,\n },\n created: 1698796800,\n description:\n \"Modèle DALL-E 3 d'OpenAI pour la synthèse d'images haute fidélité avec reformulation automatique des prompts.\",\n endpoints: [\"/v1/images/generations\"],\n features: [\"text-to-image\"],\n form: \"openai-standard\",\n id: \"dall-e-3\",\n name: \"DALL-E 3\",\n object: \"model\",\n owned_by: \"openai\",\n },\n {\n capabilities: {\n async_task: true,\n image_to_image: true,\n inpainting: true,\n text_to_image: true,\n },\n created: 1667260800,\n description:\n \"Modèle classique DALL-E 2 d'OpenAI pour la génération et l'édition rapide d'images.\",\n endpoints: [\n \"/v1/images/generations\",\n \"/v1/images/edits\",\n \"/v1/images/variations\",\n ],\n features: [\"text-to-image\", \"image-to-image\"],\n form: \"openai-standard\",\n id: \"dall-e-2\",\n name: \"DALL-E 2\",\n object: \"model\",\n owned_by: \"openai\",\n },\n {\n capabilities: {\n async_task: true,\n image_to_image: false,\n inpainting: false,\n text_to_image: true,\n },\n created: 1723680000,\n description:\n \"Modèle de synthèse photoréaliste et typographique de Google DeepMind Imagen 3.\",\n endpoints: [\"/v1/images/generations\"],\n features: [\"text-to-image\"],\n form: \"openai-standard\",\n id: \"google/imagen-3\",\n name: \"Google Imagen 3\",\n object: \"model\",\n owned_by: \"google\",\n },\n {\n capabilities: {\n async_task: true,\n image_to_image: false,\n inpainting: false,\n text_to_image: true,\n },\n created: 1730000000,\n description: \"Modèle ultra-rapide de génération photoréaliste par Luma AI.\",\n endpoints: [\"/v1/images/generations\"],\n features: [\"text-to-image\"],\n form: \"openai-standard\",\n id: \"luma/photon\",\n name: \"Luma Photon\",\n object: \"model\",\n owned_by: \"luma\",\n },\n];\n\n/**\n * Déterminer la forme technique d'un modèle d'image CometAPI\n */\nfunction detectModelForm(\n modelId: string,\n _features?: string[],\n): ImageModelItem[\"form\"] {\n const lower = modelId.toLowerCase();\n if (\n lower.includes(\"midjourney\") || lower.includes(\"mj-\") ||\n lower.startsWith(\"mj/\")\n ) {\n return \"midjourney-pipeline\";\n }\n if (lower.includes(\"upscale\")) {\n return \"image-upscale\";\n }\n if (lower.includes(\"edit\") || lower.includes(\"inpaint\")) {\n return \"image-edit\";\n }\n return \"openai-standard\";\n}\n\n/**\n * Obtenir la liste ordonnée des identifiants candidats pour un modèle donné sur CometAPI\n */\nfunction getCometCandidateModelIds(requestedModel: string): string[] {\n const lower = (requestedModel || \"\").toLowerCase().trim();\n\n if (lower.includes(\"schnell\")) {\n return [\n \"flux-schnell\",\n \"black-forest-labs/flux-schnell\",\n \"flux-1-schnell\",\n \"black-forest-labs/flux-1-schnell\",\n \"dall-e-3\",\n \"gpt-image-2\",\n ];\n }\n if (lower.includes(\"flux\") && lower.includes(\"dev\")) {\n return [\n \"flux-dev\",\n \"black-forest-labs/flux-dev\",\n \"flux-1-dev\",\n \"black-forest-labs/flux-1-dev\",\n \"dall-e-3\",\n \"gpt-image-2\",\n ];\n }\n if (\n lower.includes(\"flux\") && (lower.includes(\"pro\") || lower.includes(\"ultra\"))\n ) {\n return [\n \"flux-pro\",\n \"black-forest-labs/flux-pro\",\n \"flux-1.1-pro\",\n \"black-forest-labs/flux-1.1-pro\",\n \"dall-e-3\",\n \"gpt-image-2\",\n ];\n }\n if (\n lower.includes(\"dall-e-3\") || lower.includes(\"dalle-3\") ||\n lower === \"dall-e\"\n ) {\n return [\"dall-e-3\", \"gpt-image-2\", \"openai/dall-e-3\", \"gpt-image-1\"];\n }\n if (lower.includes(\"dall-e-2\") || lower.includes(\"dalle-2\")) {\n return [\"dall-e-2\", \"openai/dall-e-2\", \"dall-e-3\"];\n }\n if (lower.includes(\"midjourney\") || lower.includes(\"mj\")) {\n return [\n \"midjourney/v6.1\",\n \"midjourney/v6\",\n \"midjourney\",\n \"mj-v6\",\n \"dall-e-3\",\n ];\n }\n if (\n lower.includes(\"diffusion\") || lower.includes(\"sd3\") ||\n lower.includes(\"sd-3\")\n ) {\n return [\n \"stable-diffusion-3.5-large\",\n \"stabilityai/stable-diffusion-3.5-large\",\n \"sdxl\",\n \"stabilityai/sdxl\",\n \"dall-e-3\",\n ];\n }\n if (lower.includes(\"sdxl\")) {\n return [\"sdxl\", \"stabilityai/sdxl\", \"dall-e-3\"];\n }\n if (lower.includes(\"recraft\")) {\n return [\"recraft-v3\", \"recraft-ai/recraft-v3\", \"dall-e-3\"];\n }\n if (lower.includes(\"ideogram\")) {\n return [\n \"ideogram-v2\",\n \"ideogram-ai/ideogram-v2\",\n \"ideogram-v2-turbo\",\n \"dall-e-3\",\n ];\n }\n if (lower.includes(\"imagen\")) {\n return [\"google/imagen-3\", \"imagen-3\", \"dall-e-3\"];\n }\n if (lower.includes(\"photon\")) {\n return [\"luma/photon\", \"photon\", \"dall-e-3\"];\n }\n\n return [requestedModel, \"flux-schnell\", \"dall-e-3\", \"gpt-image-2\"];\n}\n\n/**\n * Résolution des alias de modèles\n */\nfunction resolveImageModel(requestedModel: string): string {\n if (!requestedModel) return \"flux-schnell\";\n const candidates = getCometCandidateModelIds(requestedModel);\n return candidates[0] || requestedModel;\n}\n\n/**\n * Formatage d'un modèle d'image selon le schéma OpenAI Model Specification\n */\nfunction formatOpenAiImageModel(m: any): ImageModelItem {\n const modelId = m.id || \"image-model\";\n const org = m.owned_by || modelId.split(\"/\")[0] || \"cometapi\";\n const created = Number(m.created) ||\n Math.floor(Date.now() / 1000) - 86_400 * 30;\n const features = m.features ||\n m.supported_features ||\n (modelId.toLowerCase().includes(\"diffusion\") ||\n modelId.toLowerCase().includes(\"midjourney\")\n ? [\"text-to-image\", \"image-to-image\"]\n : [\"text-to-image\"]);\n\n const form = m.form || detectModelForm(modelId, features);\n const endpoints = m.endpoints || (\n form === \"midjourney-pipeline\"\n ? [\n \"/v1/images/generations\",\n \"/mj/submit/imagine\",\n \"/mj/submit/action\",\n \"/mj/task/:id/fetch\",\n ]\n : form === \"image-edit\"\n ? [\"/v1/images/edits\", \"/v1/images/generations\"]\n : form === \"image-upscale\"\n ? [\"/v1/images/upscale\"]\n : [\"/v1/images/generations\", \"/v1/images/edits\"]\n );\n\n return {\n capabilities: {\n async_task: true,\n image_to_image: features.includes(\"image-to-image\") ||\n form === \"image-edit\",\n inpainting: features.includes(\"inpainting\") ||\n features.includes(\"image-to-image\"),\n text_to_image: true,\n upscaling: features.includes(\"upscale\") || form === \"image-upscale\" ||\n form === \"midjourney-pipeline\",\n variation: features.includes(\"variation\") ||\n form === \"midjourney-pipeline\",\n },\n created,\n description: m.description ||\n `Modèle de génération d'images haute fidélité ${m.name || modelId}.`,\n endpoints,\n features,\n form,\n id: modelId,\n name: m.name || modelId,\n object: \"model\",\n owned_by: org,\n parent: null,\n permission: [\n {\n allow_create_engine: false,\n allow_fine_tuning: false,\n allow_logprobs: true,\n allow_sampling: true,\n allow_search_indices: false,\n allow_view: true,\n created,\n group: null,\n id: `modelperm-${modelId.replace(/[^a-zA-Z0-9]/g, \"-\")}`,\n is_blocking: false,\n object: \"model_permission\",\n organization: \"*\",\n },\n ],\n root: modelId,\n };\n}\n\n/**\n * Récupération dynamique et filtrage en temps réel des modèles d'images depuis CometAPI\n */\nasync function fetchLiveCometImageModels(): Promise<ImageModelItem[]> {\n const now = Date.now();\n if (\n cachedCometImageModels.length > 0 && now - lastCometFetchTime < CACHE_TTL_MS\n ) {\n return cachedCometImageModels;\n }\n\n const cometApiKey = getCometApiKey();\n if (!cometApiKey) {\n return FALLBACK_IMAGE_MODELS;\n }\n\n try {\n const res = await fetch(\"https://api.cometapi.com/v1/models\", {\n headers: {\n Authorization: `Bearer ${cometApiKey}`,\n \"Content-Type\": \"application/json\",\n Accept: \"application/json\",\n },\n });\n\n if (!res.ok) {\n console.warn(`[CometAPI] /v1/models réponse non-OK (${res.status})`);\n return cachedCometImageModels.length > 0\n ? cachedCometImageModels\n : FALLBACK_IMAGE_MODELS;\n }\n\n const json = await res.json();\n const rawModels: any[] = json.data || json.models || [];\n\n // Filtrage dynamique multi-formes des modèles d'image\n const imageModels = rawModels.filter((m: any) => {\n if (!m || !m.id) return false;\n const mType = String(\n m.model_type ||\n m.type ||\n m.architecture?.modality ||\n m.object ||\n \"\",\n ).toLowerCase();\n const outputModalities = (m.architecture?.output_modalities || []).map((\n o: string,\n ) => String(o).toLowerCase());\n const features = (m.features || m.supported_features || []).map((\n f: string,\n ) => String(f).toLowerCase());\n const idLower = String(m.id).toLowerCase();\n\n const isImageModality = mType.includes(\"image\") ||\n outputModalities.includes(\"image\") ||\n mType.endsWith(\"->image\") ||\n mType.includes(\"text->image\");\n\n const hasImageFeature = features.includes(\"text-to-image\") ||\n features.includes(\"image-to-image\") ||\n features.includes(\"inpainting\") ||\n features.includes(\"image\");\n\n const matchesImageKeyword = idLower.includes(\"flux\") ||\n idLower.includes(\"diffusion\") ||\n idLower.includes(\"dall-e\") ||\n idLower.includes(\"midjourney\") ||\n idLower.includes(\"mj-\") ||\n idLower.includes(\"recraft\") ||\n idLower.includes(\"ideogram\") ||\n idLower.includes(\"imagen\") ||\n idLower.includes(\"photon\") ||\n idLower.includes(\"kling\") ||\n idLower.includes(\"kolors\") ||\n idLower.includes(\"sdxl\") ||\n idLower.includes(\"stable-diffusion\") ||\n idLower.startsWith(\"sd-\") ||\n idLower.includes(\"qwen-image\") ||\n idLower.includes(\"gpt-image\");\n\n return isImageModality || hasImageFeature || matchesImageKeyword;\n });\n\n if (imageModels.length > 0) {\n const formatted = imageModels.map(formatOpenAiImageModel);\n cachedCometImageModels = formatted;\n lastCometFetchTime = now;\n return formatted;\n }\n\n return cachedCometImageModels.length > 0\n ? cachedCometImageModels\n : FALLBACK_IMAGE_MODELS;\n } catch (err) {\n console.error(\"[CometAPI] Erreur de récupération des modèles:\", err);\n return cachedCometImageModels.length > 0\n ? cachedCometImageModels\n : FALLBACK_IMAGE_MODELS;\n }\n}\n\n/**\n * Exécuteur robuste multi-stratégie pour la génération d'images CometAPI\n */\nasync function callCometImageGeneration(params: {\n apiKey: string;\n isEdit?: boolean;\n isVariation?: boolean;\n mask?: string;\n model: string;\n n: number;\n negativePrompt?: string;\n prompt: string;\n quality?: string;\n responseFormat?: string;\n seed?: number;\n size: string;\n sourceImage?: string;\n style?: string;\n}): Promise<\n {\n data: Array<{ b64_json?: string; revised_prompt?: string; url?: string }>;\n usedModel: string;\n }\n> {\n const {\n apiKey,\n prompt,\n size,\n n,\n responseFormat,\n quality,\n style,\n negativePrompt,\n seed,\n sourceImage,\n mask,\n isEdit,\n isVariation,\n } = params;\n\n const candidateModels = getCometCandidateModelIds(params.model);\n let lastErrorText = \"\";\n\n for (const candidate of candidateModels) {\n // 1. Construire le payload de base minimal\n const basePayload: Record<string, unknown> = {\n model: candidate,\n prompt,\n size: size || \"1024x1024\",\n };\n\n if (n && n > 1) {\n basePayload.n = Math.min(n, 4);\n }\n if (responseFormat && responseFormat === \"b64_json\") {\n basePayload.response_format = \"b64_json\";\n }\n if (quality) {\n basePayload.quality = quality;\n }\n if (style) {\n basePayload.style = style;\n }\n if (negativePrompt) {\n basePayload.negative_prompt = negativePrompt;\n }\n if (seed !== undefined) {\n basePayload.seed = seed;\n }\n if (sourceImage) {\n basePayload.image = sourceImage;\n }\n if (mask) {\n basePayload.mask = mask;\n }\n\n const endpointUrl = isEdit\n ? \"https://api.cometapi.com/v1/images/edits\"\n : isVariation\n ? \"https://api.cometapi.com/v1/images/variations\"\n : \"https://api.cometapi.com/v1/images/generations\";\n\n let currentPayload = { ...basePayload };\n\n for (let attempt = 0; attempt < 2; attempt++) {\n try {\n const res = await fetch(endpointUrl, {\n body: JSON.stringify(currentPayload),\n headers: {\n Authorization: `Bearer ${apiKey}`,\n \"Content-Type\": \"application/json\",\n Accept: \"application/json\",\n },\n method: \"POST\",\n });\n\n if (res.ok) {\n const json = await res.json().catch(() => ({}));\n const rawList = json.data || json.images || [];\n if (Array.isArray(rawList) && rawList.length > 0) {\n const formatted = rawList.map((img: any) => {\n const rawUrl = img.url || \"\";\n const b64 = img.b64_json || \"\";\n const resolved = normalizeImageSrc(rawUrl || b64);\n return {\n b64_json: b64 ||\n (responseFormat === \"b64_json\" && resolved.startsWith(\"data:\")\n ? resolved.split(\",\")[1]\n : undefined),\n revised_prompt: img.revised_prompt || prompt,\n url: resolved || rawUrl,\n };\n });\n return { data: formatted, usedModel: candidate };\n }\n }\n\n lastErrorText = await res.text().catch(() => \"\");\n console.warn(\n `[CometAPI] Modèle '${candidate}' tentative ${\n attempt + 1\n } échouée (${res.status}):`,\n lastErrorText,\n );\n\n // Si l'erreur indique un paramètre inconnu (ex: 'style', 'quality', 'seed', etc.)\n if (\n lastErrorText.includes(\"Unknown parameter\") ||\n lastErrorText.includes(\"unknown_parameter\")\n ) {\n // Supprimer les paramètres optionnels et re-tenter immédiatement\n currentPayload = {\n model: candidate,\n prompt,\n size: size || \"1024x1024\",\n };\n continue;\n }\n } catch (fetchErr: unknown) {\n lastErrorText = fetchErr instanceof Error\n ? fetchErr.message\n : \"Erreur réseau\";\n console.warn(\n `[CometAPI] Exception fetch '${candidate}':`,\n lastErrorText,\n );\n }\n break;\n }\n }\n\n // 2. Fallback alternatif : essayer via /v1/chat/completions sur CometAPI\n try {\n const chatRes = await fetch(\n \"https://api.cometapi.com/v1/chat/completions\",\n {\n body: JSON.stringify({\n messages: [\n {\n content: `Generate this image: ${prompt}`,\n role: \"user\",\n },\n ],\n model: \"dall-e-3\",\n }),\n headers: {\n Authorization: `Bearer ${apiKey}`,\n \"Content-Type\": \"application/json\",\n Accept: \"application/json\",\n },\n method: \"POST\",\n },\n );\n\n if (chatRes.ok) {\n const chatJson = await chatRes.json();\n const content = chatJson.choices?.[0]?.message?.content || \"\";\n const match = content.match(/!\\[.*?\\]\$(https?:\\/\\/[^\\s\$]+)\\)/) ||\n content.match(/(https?:\\/\\/[^\\s\\)]+\\.(?:png|jpg|jpeg|webp))/i);\n if (match && match[1]) {\n return {\n data: [\n {\n revised_prompt: prompt,\n url: normalizeImageSrc(match[1]),\n },\n ],\n usedModel: \"chat-image-fallback\",\n };\n }\n }\n } catch {}\n\n throw new Error(\n `Erreur fournisseur Comet API: ${\n lastErrorText ||\n \"Impossible de générer l'image après plusieurs tentatives\"\n }`,\n );\n}\n\n/**\n * Exécuteur et pont asynchrone pour les tâches Midjourney sur CometAPI\n */\nasync function executeMidjourneyImagineBridge(\n prompt: string,\n cometApiKey: string,\n options?: {\n aspectRatio?: string;\n base64Array?: string[];\n notifyHook?: string;\n },\n): Promise<\n { failReason?: string; imageUrl: string; progress?: string; taskId?: string }\n> {\n let finalPrompt = prompt.trim();\n if (options?.aspectRatio && !finalPrompt.includes(\"--ar\")) {\n finalPrompt = `${finalPrompt} --ar ${options.aspectRatio}`;\n }\n\n const payload: Record<string, unknown> = {\n prompt: finalPrompt,\n };\n if (options?.base64Array && options.base64Array.length > 0) {\n payload.base64Array = options.base64Array;\n }\n if (options?.notifyHook) {\n payload.notifyHook = options.notifyHook;\n }\n\n try {\n const submitRes = await fetch(\n \"https://api.cometapi.com/mj/submit/imagine\",\n {\n body: JSON.stringify(payload),\n headers: {\n Authorization: `Bearer ${cometApiKey}`,\n \"Content-Type\": \"application/json\",\n Accept: \"application/json\",\n },\n method: \"POST\",\n },\n );\n\n if (submitRes.ok) {\n const submitJson = await submitRes.json();\n const taskId = submitJson.result || submitJson.task_id || submitJson.id;\n\n if (taskId) {\n // Polling actif jusqu'à succès (max 60s)\n const maxAttempts = 35;\n const pollIntervalMs = 1800;\n\n for (let attempt = 0; attempt < maxAttempts; attempt++) {\n await new Promise((resolve) => setTimeout(resolve, pollIntervalMs));\n\n try {\n const fetchRes = await fetch(\n `https://api.cometapi.com/mj/task/${taskId}/fetch`,\n {\n headers: {\n Authorization: `Bearer ${cometApiKey}`,\n \"Content-Type\": \"application/json\",\n Accept: \"application/json\",\n },\n },\n );\n\n if (!fetchRes.ok) continue;\n\n const taskJson = await fetchRes.json();\n const status = String(taskJson.status || \"\").toUpperCase();\n\n if (status === \"SUCCESS\") {\n const imgUrl = taskJson.imageUrl || taskJson.cdnImage ||\n taskJson.discordImage || taskJson.image_url;\n if (imgUrl) {\n return {\n imageUrl: imgUrl,\n progress: \"100%\",\n taskId,\n };\n }\n } else if (status === \"FAILURE\" || status === \"FAILED\") {\n break;\n }\n } catch {}\n }\n }\n }\n } catch (err) {\n console.warn(\"[CometAPI] Midjourney imagine bridge error:\", err);\n }\n\n // Si le bridge MJ natif échoue ou timeout, fallback transparent sur les générateurs d'images CometAPI\n const fallbackRes = await callCometImageGeneration({\n apiKey: cometApiKey,\n model: \"dall-e-3\",\n n: 1,\n prompt,\n size: \"1024x1024\",\n });\n\n return {\n imageUrl: fallbackRes.data[0]?.url || \"\",\n progress: \"100%\",\n taskId: \"fallback-standard\",\n };\n}\n\nexport function registerImageRoutes(app: Hono) {\n // ─────────────────────────────────────────────\n // GET /v1/models/images, /models/images & /v1/images/models (OpenAI Compatible)\n // ─────────────────────────────────────────────\n const handleGetImageModels = async (c: any) => {\n const userPlan = c.get(\"userPlan\");\n const planStr = String(userPlan || \"Free\")\n .toLowerCase()\n .trim();\n const isPaidPlan = [\"plus\", \"pro\", \"max\"].includes(planStr);\n const shouldFilterFreeOnly = !isPaidPlan;\n\n try {\n let models = await fetchLiveCometImageModels();\n\n if (shouldFilterFreeOnly) {\n models = models.filter((m) => {\n const idLower = (m.id || \"\").toLowerCase();\n return idLower.includes(\"flux\") || idLower.includes(\"schnell\") ||\n idLower.includes(\"free\");\n });\n }\n\n return c.json({ data: models, object: \"list\" });\n } catch (_err) {\n let fallback = FALLBACK_IMAGE_MODELS;\n if (shouldFilterFreeOnly) {\n fallback = fallback.filter((m) => m.id.toLowerCase().includes(\"flux\"));\n }\n return c.json({\n data: fallback.map(formatOpenAiImageModel),\n object: \"list\",\n });\n }\n };\n\n app.get(\"/v1/models/images\", handleGetImageModels);\n app.get(\"/models/images\", handleGetImageModels);\n app.get(\"/v1/images/models\", handleGetImageModels);\n app.get(\"/images/models\", handleGetImageModels);\n\n // ─────────────────────────────────────────────\n // GET /v1/models/images/:id & /models/images/:id (OpenAI Model Detail)\n // ─────────────────────────────────────────────\n const handleGetSingleImageModel = async (c: any) => {\n const rawId = c.req.param(\"id\") || \"\";\n const resolvedId = resolveImageModel(rawId);\n\n const liveModels = await fetchLiveCometImageModels();\n const found = liveModels.find(\n (m) =>\n m.id.toLowerCase() === rawId.toLowerCase() ||\n m.id.toLowerCase() === resolvedId.toLowerCase() ||\n m.name.toLowerCase() === rawId.toLowerCase(),\n ) ||\n FALLBACK_IMAGE_MODELS.find(\n (m) =>\n m.id.toLowerCase() === rawId.toLowerCase() ||\n m.id.toLowerCase() === resolvedId.toLowerCase() ||\n m.name.toLowerCase() === rawId.toLowerCase(),\n ) || {\n created: Math.floor(Date.now() / 1000),\n description: `Modèle d'image ${rawId}.`,\n features: [\"text-to-image\"],\n form: detectModelForm(resolvedId, [\"text-to-image\"]),\n id: resolvedId,\n name: rawId,\n object: \"model\" as const,\n owned_by: resolvedId.split(\"/\")[0] || \"cometapi\",\n };\n\n return c.json(formatOpenAiImageModel(found));\n };\n\n app.get(\"/v1/models/images/:id\", handleGetSingleImageModel);\n app.get(\"/models/images/:id\", handleGetSingleImageModel);\n\n // ─────────────────────────────────────────────\n // GET /v1/images/usage & /images/usage\n // ─────────────────────────────────────────────\n const handleGetImageUsage = 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 // Token non JWT ignoré\n }\n }\n\n const sql = getDb();\n\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 // Erreur DB ignorée\n }\n }\n\n if (!userId) {\n return c.json({ error: \"Non authentifié.\" }, 401);\n }\n\n const [uRows, countRows] = 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(images_generated::numeric), 0) as images_generated \n FROM mprojects_daily_image_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 usage_date = CURRENT_DATE \n LIMIT 1\n `.catch(() => []),\n ]);\n\n const effectiveTier = uRows[0]?.tier || userPlan || \"Free\";\n const usedToday = Number(countRows[0]?.images_generated || 0);\n const dailyLimit = getTierDailyImageLimit(effectiveTier);\n\n const now = new Date();\n const tomorrowMidnight = new Date(\n Date.UTC(\n now.getUTCFullYear(),\n now.getUTCMonth(),\n now.getUTCDate() + 1,\n 0,\n 0,\n 0,\n ),\n );\n\n return c.json({\n dailyLimit,\n plan: effectiveTier,\n resetAt: tomorrowMidnight.toISOString(),\n usedToday,\n userId,\n });\n } catch (err: unknown) {\n const msg = err instanceof Error ? err.message : \"Erreur inconnue\";\n return c.json(\n {\n details: msg,\n error: \"Erreur lors de la récupération de l'usage image.\",\n },\n 500,\n );\n }\n };\n\n app.get(\"/v1/images/usage\", handleGetImageUsage);\n app.get(\"/images/usage\", handleGetImageUsage);\n\n // ─────────────────────────────────────────────\n // GET /v1/images/history & /images/history\n // ─────────────────────────────────────────────\n const handleGetImageHistory = 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 // Token invalide ignoré\n }\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, model, prompt, negative_prompt, width, height, image_url, status, created_at\n FROM mprojects_image_generations\n WHERE user_id = ${userId}::text\n ORDER BY created_at DESC\n LIMIT 50\n `;\n\n const formattedHistory = history.map((item: any) => ({\n ...item,\n image_url: normalizeImageSrc(item.image_url),\n }));\n\n return c.json({ data: formattedHistory, success: true });\n } catch (err: unknown) {\n const msg = err instanceof Error ? err.message : \"Erreur inconnue\";\n return c.json(\n { details: msg, error: \"Erreur historique images.\" },\n 500,\n );\n }\n };\n\n app.get(\"/v1/images/history\", handleGetImageHistory);\n app.get(\"/images/history\", handleGetImageHistory);\n\n // ─────────────────────────────────────────────\n // POST /v1/images/generations & Formes Multi-Modèles (OpenAI, Midjourney, Google SDK)\n // ─────────────────────────────────────────────\n const handleImageGeneration = 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;\n userPlan = (payload.tier as string) || userPlan;\n } catch {\n // Token non JWT ignoré\n }\n }\n\n if (!userId) {\n return c.json(\n {\n error: {\n code: \"invalid_api_key\",\n message: \"Non authentifié. Clé API ou token requis.\",\n param: null,\n type: \"authentication_error\",\n },\n },\n 401,\n );\n }\n\n const body = await c.req.json().catch(() => ({}));\n const reqPath = c.req.path || \"\";\n const isGoogleFormat = reqPath.includes(\":generateImages\") ||\n reqPath.includes(\":predict\") ||\n Boolean(body.instances || body.numberOfImages || body.aspectRatio);\n\n const rawPrompt = body.prompt ||\n body.instances?.[0]?.prompt ||\n body.parameters?.prompt ||\n \"\";\n const prompt = typeof rawPrompt === \"string\" ? rawPrompt.trim() : \"\";\n\n const pathModel = reqPath\n .replace(/^\\/(v1beta|v1)\\/models\\//, \"\")\n .replace(/:(generateImages|predict).*$/, \"\");\n const requestedModel = body.model || pathModel ||\n \"black-forest-labs/flux-schnell\";\n\n const model = resolveImageModel(requestedModel);\n const modelForm = detectModelForm(model, []);\n\n // Résolution des dimensions et aspect ratio\n let width = 1024;\n let height = 1024;\n const aspectRatioStr = body.aspect_ratio || body.aspectRatio || \"\";\n\n if (aspectRatioStr) {\n const ar = String(aspectRatioStr).trim();\n if (ar === \"16:9\") {\n width = 1280;\n height = 720;\n } else if (ar === \"9:16\") {\n width = 720;\n height = 1280;\n } else if (ar === \"4:3\") {\n width = 1024;\n height = 768;\n } else if (ar === \"3:4\") {\n width = 768;\n height = 1024;\n } else if (ar === \"21:9\") {\n width = 1536;\n height = 640;\n }\n } else if (body.size) {\n const parts = String(body.size).split(\"x\");\n if (parts.length === 2) {\n width = Number.parseInt(parts[0], 10) || 1024;\n height = Number.parseInt(parts[1], 10) || 1024;\n }\n } else {\n if (body.width) width = Number(body.width);\n if (body.height) height = Number(body.height);\n }\n\n const negativePrompt = body.negative_prompt || \"\";\n const n = Math.max(\n 1,\n Math.min(Number(body.n || body.numberOfImages || 1), 4),\n );\n const responseFormat = body.response_format || \"url\";\n const quality = body.quality ? String(body.quality) : undefined;\n const style = body.style ? String(body.style) : undefined;\n\n if (!prompt) {\n return c.json(\n {\n error: {\n code: \"missing_prompt\",\n message:\n \"Le paramètre 'prompt' est obligatoire pour la génération d'images.\",\n param: \"prompt\",\n type: \"invalid_request_error\",\n },\n },\n 400,\n );\n }\n\n const sql = getDb();\n\n // Vérifier le forfait utilisateur réel\n const uRows = await sql`\n SELECT tier FROM users \n WHERE id::text = ${userId}::text OR username = ${userId}::text \n LIMIT 1\n `;\n const effectiveTier = uRows[0]?.tier || userPlan || \"Free\";\n const planStr = effectiveTier.toLowerCase().trim();\n const isPaidPlan = [\"plus\", \"pro\", \"max\"].includes(planStr);\n\n if (!isPaidPlan) {\n return c.json(\n {\n error: {\n code: \"image_generation_tier_restricted\",\n message:\n `La génération d'images via l'API est réservée aux abonnements payants (Plus, Pro, Max). Les clés API issues d'un compte Free ne sont pas autorisées à effectuer de requêtes de génération d'images.`,\n param: null,\n type: \"permission_error\",\n },\n },\n 403,\n );\n }\n\n // Quota journalier\n const dailyLimit = getTierDailyImageLimit(effectiveTier);\n const usageRows = await sql`\n SELECT images_generated \n FROM mprojects_daily_image_usage \n WHERE user_id = ${userId}::text AND usage_date = CURRENT_DATE \n LIMIT 1\n `;\n const currentDailyUsage = Number(usageRows[0]?.images_generated || 0);\n\n if (currentDailyUsage >= dailyLimit) {\n return c.json(\n {\n error: {\n code: \"daily_image_quota_exceeded\",\n limit: dailyLimit,\n message:\n `Votre quota journalier de génération d'images est épuisé (${currentDailyUsage}/${dailyLimit} par jour pour le forfait ${effectiveTier}). Réinitialisation automatique à minuit UTC.`,\n type: \"quota_error\",\n used: currentDailyUsage,\n },\n },\n 429,\n );\n }\n\n // Appel de Comet API avec exécution multi-stratégie & gestion des erreurs\n const cometApiKey = getCometApiKey();\n let generatedImageUrl = \"\";\n let cometResultData: Array<\n { b64_json?: string; revised_prompt?: string; url?: string }\n > = [];\n let finalUsedModel = model;\n\n if (cometApiKey) {\n if (\n modelForm === \"midjourney-pipeline\" && !reqPath.includes(\"/edits\")\n ) {\n const mjRes = await executeMidjourneyImagineBridge(\n prompt,\n cometApiKey,\n {\n aspectRatio: aspectRatioStr ||\n (width !== height ? `${width}:${height}` : undefined),\n base64Array: body.image ? [body.image] : undefined,\n },\n );\n generatedImageUrl = normalizeImageSrc(mjRes.imageUrl);\n cometResultData = [{\n revised_prompt: prompt,\n url: generatedImageUrl,\n }];\n } else {\n const genResult = await callCometImageGeneration({\n apiKey: cometApiKey,\n isEdit: reqPath.includes(\"/edits\") ||\n Boolean(body.image && body.mask),\n isVariation: reqPath.includes(\"/variations\"),\n mask: body.mask,\n model,\n n,\n negativePrompt,\n prompt,\n quality,\n responseFormat,\n seed: body.seed,\n size: `${width}x${height}`,\n sourceImage: body.image || body.image_url,\n style,\n });\n\n cometResultData = genResult.data;\n finalUsedModel = genResult.usedModel;\n if (cometResultData.length > 0) {\n generatedImageUrl = cometResultData[0].url || \"\";\n }\n }\n } else {\n generatedImageUrl = `https://picsum.photos/seed/${\n encodeURIComponent(prompt.slice(0, 20))\n }/${width}/${height}`;\n cometResultData = [{ revised_prompt: prompt, url: generatedImageUrl }];\n }\n\n // Incrémentation du quota journalier\n await sql`\n INSERT INTO mprojects_daily_image_usage (user_id, usage_date, images_generated, updated_at)\n VALUES (${userId}::text, CURRENT_DATE, 1, NOW())\n ON CONFLICT (user_id, usage_date)\n DO UPDATE SET \n images_generated = mprojects_daily_image_usage.images_generated + 1,\n updated_at = NOW()\n `;\n\n // Enregistrement dans l'historique\n await sql`\n INSERT INTO mprojects_image_generations (\n user_id, api_key, model, prompt, negative_prompt, width, height, image_url, status\n ) VALUES (\n ${userId}::text,\n ${apiKey || null},\n ${finalUsedModel}::text,\n ${prompt}::text,\n ${negativePrompt || null},\n ${width}::integer,\n ${height}::integer,\n ${generatedImageUrl}::text,\n 'completed'\n )\n `;\n\n // Incrémentation du compteur de requêtes de la clé API\n const requestCost = getTierImageRequestCost(effectiveTier);\n if (apiKey) {\n await sql`\n UPDATE mprojects_api_keys\n SET request_count = request_count + ${requestCost}, last_used_at = NOW()\n WHERE api_key = ${apiKey}\n `;\n }\n\n // Log de requête\n try {\n await sql`\n INSERT INTO mprojects_api_logs (api_key, endpoint, method, status_code, latency_ms, created_at)\n VALUES (${apiKey || \"anonymous\"}::text, ${\n reqPath || \"/v1/images/generations\"\n }::text, 'POST', 200, 1500, NOW())\n `;\n } catch {}\n\n // Format Google GenAI\n if (isGoogleFormat) {\n return c.json({\n generatedImages: cometResultData.map((img) => ({\n image: {\n imageBytes: img.b64_json || \"\",\n mimeType: \"image/png\",\n uri: img.url || generatedImageUrl,\n },\n })),\n });\n }\n\n // Format OpenAI Standard\n return c.json({\n created: Math.floor(Date.now() / 1000),\n data: cometResultData,\n model: finalUsedModel,\n usage: {\n daily_limit: dailyLimit,\n daily_used: currentDailyUsage + 1,\n plan: effectiveTier,\n request_cost: requestCost,\n requests_counted: requestCost,\n },\n });\n } catch (err: unknown) {\n const msg = err instanceof Error ? err.message : \"Erreur inconnue\";\n console.error(\"[ImagesAPI] Erreur serveur génération:\", err);\n return c.json(\n {\n error: {\n code: \"image_generation_failed\",\n details: msg,\n message: `Erreur lors de la génération d'image : ${msg}`,\n type: \"api_error\",\n },\n },\n 500,\n );\n }\n };\n\n // ─────────────────────────────────────────────\n // POST & GET Routes Midjourney Dédiées (`/mj/*` et `/v1/mj/*`)\n // ─────────────────────────────────────────────\n const handleMidjourneyForward = async (c: any) => {\n const cometApiKey = getCometApiKey();\n if (!cometApiKey) {\n return c.json({\n error: \"Clé COMET_API_KEY non configurée sur le serveur.\",\n }, 500);\n }\n\n const subPath = c.req.path.replace(/^\\/v1\\/mj\\//, \"\").replace(\n /^\\/mj\\//,\n \"\",\n );\n const targetUrl = `https://api.cometapi.com/mj/${subPath}`;\n const method = c.req.method;\n\n try {\n const init: RequestInit = {\n headers: {\n Authorization: `Bearer ${cometApiKey}`,\n \"Content-Type\": \"application/json\",\n Accept: \"application/json\",\n },\n method,\n };\n\n if (method === \"POST\" || method === \"PUT\" || method === \"PATCH\") {\n const reqBody = await c.req.json().catch(() => ({}));\n init.body = JSON.stringify(reqBody);\n }\n\n const res = await fetch(targetUrl, init);\n const data = await res.json().catch(() => ({}));\n return c.json(data, res.status as any);\n } catch (err: unknown) {\n const msg = err instanceof Error ? err.message : \"Erreur inconnue\";\n return c.json(\n { error: \"Erreur proxy Midjourney CometAPI\", details: msg },\n 500,\n );\n }\n };\n\n app.post(\"/mj/submit/imagine\", handleMidjourneyForward);\n app.post(\"/v1/mj/submit/imagine\", handleMidjourneyForward);\n app.get(\"/mj/task/:id/fetch\", handleMidjourneyForward);\n app.get(\"/v1/mj/task/:id/fetch\", handleMidjourneyForward);\n app.post(\"/mj/submit/action\", handleMidjourneyForward);\n app.post(\"/v1/mj/submit/action\", handleMidjourneyForward);\n app.post(\"/mj/submit/describe\", handleMidjourneyForward);\n app.post(\"/v1/mj/submit/describe\", handleMidjourneyForward);\n app.post(\"/mj/submit/blend\", handleMidjourneyForward);\n app.post(\"/v1/mj/submit/blend\", handleMidjourneyForward);\n app.post(\"/mj/submit/change\", handleMidjourneyForward);\n app.post(\"/v1/mj/submit/change\", handleMidjourneyForward);\n app.post(\"/mj/submit/modal\", handleMidjourneyForward);\n app.post(\"/v1/mj/submit/modal\", handleMidjourneyForward);\n app.post(\"/mj/submit/shorten\", handleMidjourneyForward);\n app.post(\"/v1/mj/submit/shorten\", handleMidjourneyForward);\n app.post(\"/mj/submit/swap-face\", handleMidjourneyForward);\n app.post(\"/v1/mj/submit/swap-face\", handleMidjourneyForward);\n\n // ─────────────────────────────────────────────\n // POST & GET Routes Upscale, Edits, Variations & Tasks\n // ─────────────────────────────────────────────\n const handleImageUpscale = async (c: any) => {\n const cometApiKey = getCometApiKey();\n if (!cometApiKey) {\n return c.json({ error: \"Clé COMET_API_KEY non configurée.\" }, 500);\n }\n try {\n const body = await c.req.json().catch(() => ({}));\n const res = await fetch(\"https://api.cometapi.com/v1/images/upscale\", {\n body: JSON.stringify(body),\n headers: {\n Authorization: `Bearer ${cometApiKey}`,\n \"Content-Type\": \"application/json\",\n Accept: \"application/json\",\n },\n method: \"POST\",\n });\n const data = await res.json().catch(() => ({}));\n return c.json(data, res.status as any);\n } catch (err: unknown) {\n const msg = err instanceof Error ? err.message : \"Erreur inconnue\";\n return c.json({ error: \"Erreur upscale image\", details: msg }, 500);\n }\n };\n\n app.post(\"/v1/images/upscale\", handleImageUpscale);\n app.post(\"/images/upscale\", handleImageUpscale);\n\n const handleFetchImageTask = async (c: any) => {\n const taskId = c.req.param(\"id\");\n const cometApiKey = getCometApiKey();\n if (!cometApiKey) {\n return c.json({ error: \"Clé COMET_API_KEY non configurée.\" }, 500);\n }\n try {\n const res = await fetch(\n `https://api.cometapi.com/mj/task/${taskId}/fetch`,\n {\n headers: {\n Authorization: `Bearer ${cometApiKey}`,\n \"Content-Type\": \"application/json\",\n Accept: \"application/json\",\n },\n },\n );\n const data = await res.json().catch(() => ({}));\n return c.json(data, res.status as any);\n } catch (err: unknown) {\n const msg = err instanceof Error ? err.message : \"Erreur inconnue\";\n return c.json({ error: \"Erreur récupération tâche\", details: msg }, 500);\n }\n };\n\n app.get(\"/v1/images/tasks/:id\", handleFetchImageTask);\n app.get(\"/images/tasks/:id\", handleFetchImageTask);\n app.get(\"/v1/tasks/:id\", handleFetchImageTask);\n app.get(\"/tasks/:id\", handleFetchImageTask);\n\n // Routes OpenAI & Anthropic SDK\n app.post(\"/v1/images/generations\", handleImageGeneration);\n app.post(\"/images/generations\", handleImageGeneration);\n app.post(\"/v1/images\", handleImageGeneration);\n app.post(\"/images\", handleImageGeneration);\n app.post(\"/v1/images/edits\", handleImageGeneration);\n app.post(\"/images/edits\", handleImageGeneration);\n app.post(\"/v1/images/variations\", handleImageGeneration);\n app.post(\"/images/variations\", handleImageGeneration);\n\n // Routes Google GenAI / Gemini / Vertex SDK\n app.post(\"/v1beta/models/*:generateImages\", handleImageGeneration);\n app.post(\"/v1/models/*:generateImages\", handleImageGeneration);\n app.post(\"/v1beta/models/*:predict\", handleImageGeneration);\n app.post(\"/v1/models/*:predict\", handleImageGeneration);\n}",[195],"8e336185-f4bb-4cbb-8529-db37165052ee",["D",1787929713599],9,[28],"af695e83-f648-44f3-bd53-f7a6fbe86e93","devices.ts","e97247d0-9c6a-11f1-8111-1607ee4eb77e",108,["D",1787754938926],6,"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}",[206],"e8c8275f-6d88-428a-9b79-9b3d78d11c92","config.ts","e9721ca6-9c6a-11f1-8111-1607ee4eb77e",["D",1787660803355],5,"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 = \"14d\";\nexport const BCRYPT_ROUNDS = 12;\n\n// Limites de tokens hebdomadaires (Input + Output)\nexport const TIER_LIMITS: Record<string, number> = {\n Free: 2_000_000,\n Max: 20_000_000,\n Plus: 5_000_000,\n Pro: 10_000_000,\n};\n\n// Limites de tokens Speech hebdomadaires (Free: 20M, Plus: 50M, Pro: 100M, Max: 200M)\nexport const TIER_SPEECH_LIMITS: Record<string, number> = {\n Free: 20_000_000,\n free: 20_000_000,\n Gratuit: 20_000_000,\n gratuit: 20_000_000,\n Max: 200_000_000,\n max: 200_000_000,\n Plus: 50_000_000,\n plus: 50_000_000,\n Pro: 100_000_000,\n pro: 100_000_000,\n};\n\nexport function getTierSpeechLimit(tier?: string | null): number {\n const t = (tier || \"Free\").toLowerCase().trim();\n if (t === \"max\") {\n return 200_000_000;\n }\n if (t === \"pro\") {\n return 100_000_000;\n }\n if (t === \"plus\") {\n return 50_000_000;\n }\n return 20_000_000;\n}\n\nexport const TIER_REQUEST_LIMITS: Record<string, number> = {\n Free: 500,\n Max: 5000,\n Plus: 1000,\n Pro: 2000,\n};\n\n// Limites quotidiennes de génération d'images (Free: 3/j, Plus: 5/j, Pro: 10/j, Max: 20/j)\nexport const TIER_DAILY_IMAGE_LIMITS: Record<string, number> = {\n Free: 3,\n free: 3,\n Gratuit: 3,\n gratuit: 3,\n Max: 20,\n max: 20,\n Plus: 5,\n Pro: 10,\n plus: 5,\n pro: 10,\n};\n\nexport function getTierDailyImageLimit(tier?: string | null): number {\n const t = (tier || \"Free\").toLowerCase().trim();\n if (t === \"max\") {\n return 20;\n }\n if (t === \"pro\") {\n return 10;\n }\n if (t === \"plus\") {\n return 5;\n }\n return 3;\n}\n\n// Coût en requêtes API par génération d'image\n// Free = 100 requêtes, Plus = 50 requêtes, Pro = 25 requêtes, Max = 10 requêtes\nexport const TIER_IMAGE_REQUEST_COST: Record<string, number> = {\n Free: 100,\n free: 100,\n Gratuit: 100,\n gratuit: 100,\n Max: 10,\n max: 10,\n Plus: 50,\n Pro: 25,\n plus: 50,\n pro: 25,\n};\n\nexport function getTierImageRequestCost(tier?: string | null): number {\n const t = (tier || \"Free\").toLowerCase().trim();\n if (t === \"max\") {\n return 10;\n }\n if (t === \"pro\") {\n return 25;\n }\n if (t === \"plus\") {\n return 50;\n }\n return 100;\n}\n\n// Limites de stockage Cloud par tier (en bytes) — SSOT: Free 500Mo / Plus 1Go / Pro 2Go / Max 5Go\nexport const STORAGE_LIMITS_BYTES: Record<string, number> = {\n Free: 500 * 1024 * 1024, // 500 MB\n // alias lowercase pour lookup case-insensitive côté Val Town\n free: 500 * 1024 * 1024,\n gratuit: 500 * 1024 * 1024,\n Max: 5 * 1024 * 1024 * 1024, // 5 GB\n max: 5 * 1024 * 1024 * 1024,\n Plus: 1 * 1024 * 1024 * 1024, // 1 GB\n Pro: 2 * 1024 * 1024 * 1024, // 2 GB\n plus: 1 * 1024 * 1024 * 1024,\n pro: 2 * 1024 * 1024 * 1024,\n} as Record<string, number>;\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 = Deno.env.get(\"MAI_JWT_SECRET\");\n if (!secret) {\n throw new Error(\"MAI_JWT_SECRET not set\");\n }\n return new TextEncoder().encode(secret);\n}\n\n// ─────────────────────────────────────────────\n// Helpers d'authentification & Utilitaires\n// ─────────────────────────────────────────────\nexport async function signToken(\n payload: Record<string, unknown>,\n): Promise<string> {\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<Record<string, unknown>> {\n // Vérif SQLite (legacy Val Town) + Postgres (nouveau)\n const sqliteResult = await sqlite.execute({\n args: [token],\n sql: \"SELECT 1 FROM token_blacklist WHERE token = ?\",\n });\n if (sqliteResult.rows.length > 0) {\n throw new Error(\"Token révoqué.\");\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.length > 0) {\n throw new Error(\"Token révoqué.\");\n }\n } catch (e: any) {\n if (e?.message === \"Token révoqué.\") {\n throw e;\n }\n // ignore DB errors (table not yet exists)\n }\n const { payload } = await jwtVerify(token, getJwtSecret());\n return payload as Record<string, unknown>;\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 });\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<string> {\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<boolean> {\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 };",[214],"3bd24c6b-a33d-4344-9c78-c059b358db9d","auth.ts","e9719b14-9c6a-11f1-8111-1607ee4eb77e",100,["D",1787744758338],"import bcrypt from \"npm:bcryptjs\";\nimport type { Hono } from \"npm:hono@4\";\nimport {\n BCRYPT_ROUNDS,\n extractToken,\n generateVerificationCode,\n getDb,\n parseUserAgent,\n signToken,\n sqlite,\n verifyToken,\n verifyVerificationCode,\n} from \"./config.ts\";\nimport { sendVerificationEmail } from \"./email.ts\";\n\nexport function registerAuthRoutes(app: Hono) {\n // POST /register\n app.post(\"/register\", async (c) => {\n try {\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 sql = getDb();\n const existing =\n await sql`SELECT id FROM users WHERE email = ${email} OR username = ${username} 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(email, \"register\");\n await sendVerificationEmail(email, code, \"register\");\n\n return c.json({ email, status: \"verification_required\", success: true });\n } catch (err: any) {\n console.error(\"Register Error:\", err);\n return c.json({ error: \"Erreur serveur.\" }, 500);\n }\n });\n\n // POST /verify-register\n app.post(\"/verify-register\", 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 isValid = await verifyVerificationCode(email, code, \"register\");\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 email = ${email} OR username = ${username} 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 (${email}, ${username}, ${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: \"Erreur serveur.\" }, 500);\n }\n });\n\n // POST /login\n app.post(\"/login\", async (c) => {\n try {\n const { email, password, identifier } = await c.req.json();\n const loginId = (identifier || email || \"\").trim();\n if (!loginId || !password) {\n return c.json({ error: \"Champs manquants.\" }, 400);\n }\n\n const sql = getDb();\n const users =\n await sql`SELECT id, email, password_hash, tier FROM users WHERE email = ${loginId} OR username = ${loginId} OR phone = ${loginId} LIMIT 1`;\n if (users.length === 0) {\n return c.json({ error: \"Identifiants invalides.\" }, 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({ error: \"Identifiants invalides.\" }, 401);\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);\n return c.json({ error: \"Erreur serveur.\" }, 500);\n }\n });\n\n // POST /verify-login\n app.post(\"/verify-login\", async (c) => {\n try {\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(email, code, \"login\");\n if (!isValid) {\n return c.json({ error: \"Code invalide ou expiré.\" }, 400);\n }\n\n const sql = getDb();\n const users =\n await sql`SELECT id, tier FROM users WHERE email = ${email} LIMIT 1`;\n if (users.length === 0) {\n return c.json({ error: \"Utilisateur introuvable.\" }, 404);\n }\n\n const user = users[0];\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: \"Erreur serveur.\" }, 500);\n }\n });\n\n // POST /resend-code\n app.post(\"/resend-code\", 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: \"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<string, string> = {};\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: \"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();\n const existing =\n await sql`SELECT id FROM users WHERE username = ${cleanUsername} AND id::text != ${userId}::text LIMIT 1`;\n if (existing.length > 0) {\n return c.json({ error: \"Ce nom d'utilisateur est déjà pris.\" }, 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: \"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: \"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: \"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: \"Erreur serveur.\" }, 500);\n }\n });\n}",[221],"52830222-ab11-44c6-99ce-7a03fa54cce6","audio.ts","3b25ab8a-a080-11f1-99e5-1607ee4eb77e",106,["D",1787746021542],"import type { Hono } from \"npm:hono@4\";\nimport {\n extractToken,\n getDb,\n getTierSpeechLimit,\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 (_err) {\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\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 effectiveTier = 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 weeklyLimit = getTierSpeechLimit(effectiveTier);\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, 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 created_at DESC\n LIMIT 50\n `.catch(() => []);\n\n return c.json({ data: history, 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 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\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<string, string> = {\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 effectiveTier = uRows[0]?.tier || userPlan || \"Free\";\n const weeklyLimit = getTierSpeechLimit(effectiveTier);\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<string, any> = {\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 (e) {}\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 (e) {}\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 return new Response(bytes, {\n headers: {\n \"Access-Control-Allow-Origin\": \"*\",\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\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}",[228],"c459b175-1b3f-485f-bfbe-0362f0a014e3","api-middleware.ts","e972842a-9c6a-11f1-8111-1607ee4eb77e",["D",1787754938926],16,"import type { Hono } from \"npm:hono@4\";\nimport { getDb, TIER_REQUEST_LIMITS, verifyToken } 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 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 === \"/audio/speech\" ||\n path.startsWith(\"/audio/\") ||\n path === \"/usage/speech\" ||\n path === \"/usage\" ||\n path === \"/log-usage\" ||\n path === \"/v1/status\" ||\n path === \"/status\";\n\n if (!isApiRoute) {\n await next();\n return;\n }\n\n const isPublicRoute = 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\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\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 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 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 currentUserId = apiKeyData.user_id;\n matchedApiKey = apiKeyData.api_key || apiKey;\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 des quotas pour les clés API enregistrées\n if (apiKey && currentUserId && currentUserId !== \"system-mai\") {\n const tierMap: Record<string, number> = {\n Free: 500,\n Gratuit: 500,\n Max: 5000,\n Plus: 1000,\n Pro: 2000,\n };\n const limit = TIER_REQUEST_LIMITS?.[userPlan] || tierMap[userPlan] || 500;\n const sql = getDb();\n\n // Réinitialisation mensuelle automatique si le mois a changé (idempotent)\n try {\n await sql`\n UPDATE mprojects_api_keys\n SET request_count = 0\n WHERE user_id::text = ${currentUserId}::text\n AND last_used_at IS NOT NULL\n AND last_used_at < DATE_TRUNC('month', NOW())\n `;\n } catch {}\n\n // Calculer l'usage global pour l'utilisateur\n try {\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 const globalRequestCount = countRows[0]?.total_requests || 0;\n\n if (globalRequestCount >= limit) {\n if (isPublicRoute) {\n await next();\n return;\n }\n return c.json({ error: \"Quota exceeded for your account.\" }, 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 // Logging & Décompte de 1 crédit API (pour toutes les requêtes avec clé API valide incluant audio, images, web search et chat)\n const isExcludedRoute = path.startsWith(\"/v1/devices\") ||\n path === \"/v1/status\" || path === \"/status\";\n if (!isExcludedRoute && apiKey && apiKey !== systemMaiApiKey) {\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 if (status === 200) {\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}",[235],"pulls","branches",11,"forks","envVars",{"_249":159,"_252":64},"connections",{"_249":250,"_251":64},"count",1,"unfilledCount","emptyCount",{"_43":234,"_32":235,"_30":236,"_148":-5,"_41":42,"_40":208,"_150":25,"_38":303,"_13":238,"_33":34,"_35":239,"_24":25,"_154":-5,"_267":304,"_27":305},{"_43":227,"_32":228,"_30":229,"_148":-5,"_41":42,"_40":230,"_150":25,"_38":300,"_13":169,"_33":34,"_35":232,"_24":25,"_154":-5,"_267":301,"_27":302},{"_43":220,"_32":221,"_30":222,"_148":-5,"_41":42,"_40":223,"_150":25,"_38":297,"_13":217,"_33":34,"_35":225,"_24":25,"_154":-5,"_267":298,"_27":299},{"_43":213,"_32":214,"_30":215,"_148":-5,"_41":42,"_40":182,"_150":25,"_38":294,"_13":217,"_33":34,"_35":218,"_24":25,"_154":-5,"_267":295,"_27":296},{"_43":205,"_32":206,"_30":207,"_148":-5,"_41":42,"_40":208,"_150":60,"_38":291,"_13":210,"_33":34,"_35":211,"_24":25,"_154":-5,"_267":292,"_27":293},{"_43":201,"_32":28,"_30":31,"_148":-5,"_41":42,"_40":14,"_150":25,"_38":288,"_13":203,"_33":34,"_35":37,"_24":25,"_154":-5,"_267":289,"_27":290},{"_43":194,"_32":195,"_30":196,"_148":-5,"_41":42,"_40":197,"_150":25,"_38":285,"_13":161,"_33":34,"_35":199,"_24":25,"_154":-5,"_267":286,"_27":287},{"_43":188,"_32":189,"_30":190,"_148":-5,"_41":42,"_40":167,"_150":60,"_38":282,"_13":64,"_33":34,"_35":192,"_24":25,"_154":-5,"_267":283,"_27":284},{"_43":180,"_32":181,"_30":58,"_148":-5,"_41":42,"_40":182,"_150":25,"_38":279,"_13":184,"_33":185,"_35":186,"_24":25,"_154":45,"_267":280,"_27":281},{"_43":172,"_32":173,"_30":174,"_148":-5,"_41":42,"_40":175,"_150":25,"_38":276,"_13":177,"_33":34,"_35":178,"_24":25,"_154":-5,"_267":277,"_27":278},{"_43":164,"_32":165,"_30":166,"_148":-5,"_41":42,"_40":167,"_150":25,"_38":273,"_13":169,"_33":34,"_35":170,"_24":25,"_154":-5,"_267":274,"_27":275},{"_43":156,"_32":157,"_30":158,"_148":-5,"_41":42,"_40":159,"_150":25,"_38":270,"_13":161,"_33":34,"_35":162,"_24":25,"_154":-5,"_267":271,"_27":272},{"_43":145,"_32":146,"_30":147,"_148":-5,"_41":42,"_40":149,"_150":25,"_38":266,"_13":152,"_33":34,"_35":153,"_24":25,"_154":-5,"_267":268,"_27":269},["D",1787666163848],"children",[],[146],["D",1787908549794],[],[157],["D",1787587613987],[],[165],["D",1787759873515],[],[173],["D",1787660803355],[],[181],["D",1787587613987],[],[189],["D",1787812770684],[],[195],["D",1787929713599],[],[28],["D",1787754938926],[],[206],["D",1787660803355],[],[214],["D",1787744758338],[],[221],["D",1787746021542],[],[228],["D",1787754938926],[],[235],["D",1785339526786],["D",1789561254403],{"_101":100,"_109":105},{"_101":100,"_102":103,"_104":105,"_18":56,"_106":107,"_108":25},{"_13":90,"_32":91,"_43":42,"_92":44,"_93":-5,"_94":-5,"_95":-5,"_96":-5,"_97":-5,"_98":45,"_99":100},"ctx",{"_83":-5,"_129":344,"_345":346,"_347":348,"_349":25,"_350":25,"_351":25,"_352":60,"_353":-5,"_354":-7,"_355":-7,"_356":64,"_357":25,"_358":25,"_359":-5,"_360":25,"_361":25,"_362":25,"_363":-5},"ENV",{"_315":316,"_317":318,"_319":91,"_320":321,"_322":323,"_324":325,"_326":327,"_328":329,"_330":331,"_332":333,"_334":335,"_336":337,"_338":339,"_340":341,"_342":343},"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"] </article></body></html>

Diff · v119