([\\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}","children",[],[191],"9866fb6c-fec6-4cd1-9247-ffd66f920605","storage.ts","01a0439e-799b-71f2-9deb-8c73c6f1d6ef",["D",1787843101251],2,"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 cleanUrl(url: string, removeDefaultPort = true): string {\n let cleaned = (url || \"\").trim();\n if (cleaned.endsWith(\"/\")) {\n cleaned = cleaned.slice(0, -1);\n }\n if (removeDefaultPort) {\n // Normalise https://domaine.com:443 -> https://domaine.com pour des URLs publiques propres\n cleaned = cleaned.replace(\n /^https:\\/\\/([^/:]+):443(\\/.*)?$/,\n \"https://$1$2\",\n );\n cleaned = cleaned.replace(/^http:\\/\\/([^/:]+):80(\\/.*)?$/, \"http://$1$2\");\n }\n return cleaned;\n}\n\n/**\n * 10 buckets Z1 Storage par défaut en fallback (mai-storage-1 à mai-storage-10)\n */\nexport const DEFAULT_Z1_FALLBACK_BUCKETS = [\n \"mai-storage-1\",\n \"mai-storage-2\",\n \"mai-storage-3\",\n \"mai-storage-4\",\n \"mai-storage-5\",\n \"mai-storage-6\",\n \"mai-storage-7\",\n \"mai-storage-8\",\n \"mai-storage-9\",\n \"mai-storage-10\",\n];\n\nexport const TOTAL_STORAGE_NODES_COUNT = 10;\n\n/**\n * Récupère la liste des nœuds de stockage Z1 Storage / S3 configurés.\n * Supporte jusqu'à 10 comptes/buckets distincts (S3_BUCKET_1..10 / Z1_BUCKET_1..10) pour multiplier l'espace,\n * ou une liste séparée par des virgules (S3_BUCKETS / Z1_BUCKETS),\n * ou un pool de 10 buckets Z1 Storage (mai-storage-1 à mai-storage-10) en fallback automatique.\n */\nexport function getStorageNodes(): StorageNode[] {\n const nodes: StorageNode[] = [];\n\n const baseAccessKey = Deno.env.get(\"S3_ACCESS_KEY_ID\") ||\n Deno.env.get(\"Z1_ACCESS_KEY_ID\") ||\n \"\";\n const baseSecretKey = Deno.env.get(\"S3_SECRET_ACCESS_KEY\") ||\n Deno.env.get(\"Z1_SECRET_ACCESS_KEY\") ||\n \"\";\n const baseRawEndpoint = Deno.env.get(\"S3_ENDPOINT\") ||\n Deno.env.get(\"Z1_ENDPOINT\") ||\n \"https://s3.z1storage.com\";\n const baseEndpoint = cleanUrl(baseRawEndpoint);\n const baseRegion = Deno.env.get(\"S3_REGION\") ||\n Deno.env.get(\"Z1_REGION\") ||\n \"auto\";\n const baseBucket = Deno.env.get(\"S3_BUCKET\") ||\n Deno.env.get(\"Z1_BUCKET\") ||\n \"mai-storage-1\";\n const basePublicUrl = Deno.env.get(\"S3_PUBLIC_URL\") ||\n Deno.env.get(\"Z1_PUBLIC_URL\");\n\n // 1. Détection des configurations individuelles S3_BUCKET_1 à S3_BUCKET_10 (ou Z1_BUCKET_1 à 10)\n for (let i = 1; i <= TOTAL_STORAGE_NODES_COUNT; i++) {\n const bucket = Deno.env.get(`S3_BUCKET_${i}`) ||\n Deno.env.get(`S3_BUCKET${i}`) ||\n Deno.env.get(`Z1_BUCKET_${i}`) ||\n Deno.env.get(`Z1_BUCKET${i}`);\n const accessKeyId = Deno.env.get(`S3_ACCESS_KEY_ID_${i}`) ||\n Deno.env.get(`S3_ACCESS_KEY_ID${i}`) ||\n Deno.env.get(`Z1_ACCESS_KEY_ID_${i}`) ||\n Deno.env.get(`Z1_ACCESS_KEY_ID${i}`) ||\n baseAccessKey;\n const secretAccessKey = Deno.env.get(`S3_SECRET_ACCESS_KEY_${i}`) ||\n Deno.env.get(`S3_SECRET_ACCESS_KEY${i}`) ||\n Deno.env.get(`Z1_SECRET_ACCESS_KEY_${i}`) ||\n Deno.env.get(`Z1_SECRET_ACCESS_KEY${i}`) ||\n baseSecretKey;\n const rawEndpoint = Deno.env.get(`S3_ENDPOINT_${i}`) ||\n Deno.env.get(`S3_ENDPOINT${i}`) ||\n Deno.env.get(`Z1_ENDPOINT_${i}`) ||\n Deno.env.get(`Z1_ENDPOINT${i}`) ||\n baseEndpoint;\n const endpoint = cleanUrl(rawEndpoint);\n const region = Deno.env.get(`S3_REGION_${i}`) ||\n Deno.env.get(`S3_REGION${i}`) ||\n Deno.env.get(`Z1_REGION_${i}`) ||\n Deno.env.get(`Z1_REGION${i}`) ||\n baseRegion;\n const rawPublicUrl = Deno.env.get(`S3_PUBLIC_URL_${i}`) ||\n Deno.env.get(`S3_PUBLIC_URL${i}`) ||\n Deno.env.get(`Z1_PUBLIC_URL_${i}`) ||\n Deno.env.get(`Z1_PUBLIC_URL${i}`);\n\n let publicUrl = \"\";\n if (rawPublicUrl) {\n publicUrl = cleanUrl(rawPublicUrl);\n } else if (basePublicUrl) {\n publicUrl = `${cleanUrl(basePublicUrl)}/${bucket}`;\n } else if (bucket) {\n publicUrl = `${endpoint}/${bucket}`;\n }\n\n if (bucket && accessKeyId && secretAccessKey) {\n nodes.push({\n id: i,\n endpoint,\n region,\n accessKeyId,\n secretAccessKey,\n bucket,\n publicUrl: publicUrl || `${endpoint}/${bucket}`,\n });\n }\n }\n\n // 2. Si S3_BUCKETS ou Z1_BUCKETS (liste séparée par des virgules) est configuré\n if (nodes.length === 0) {\n const bucketsList = Deno.env.get(\"S3_BUCKETS\") ||\n Deno.env.get(\"Z1_BUCKETS\");\n if (bucketsList) {\n const bucketNames = bucketsList\n .split(\",\")\n .map((b) => b.trim())\n .filter(Boolean);\n\n bucketNames.forEach((bucket, idx) => {\n const id = idx + 1;\n let publicUrl = \"\";\n if (basePublicUrl) {\n publicUrl = `${cleanUrl(basePublicUrl)}/${bucket}`;\n } else {\n publicUrl = `${baseEndpoint}/${bucket}`;\n }\n\n nodes.push({\n id,\n endpoint: baseEndpoint,\n region: baseRegion,\n accessKeyId: baseAccessKey,\n secretAccessKey: baseSecretKey,\n bucket,\n publicUrl,\n });\n });\n }\n }\n\n // 3. Fallback automatique : 10 buckets Z1 Storage (mai-storage-1 à mai-storage-10)\n // Si moins de 10 nœuds sont configurés, on complète avec les 10 buckets Z1 Storage en fallback\n if (nodes.length < TOTAL_STORAGE_NODES_COUNT) {\n const fallbackEnvList = (\n Deno.env.get(\"Z1_FALLBACK_BUCKETS\") ||\n Deno.env.get(\"S3_FALLBACK_BUCKETS\") ||\n \"\"\n )\n .split(\",\")\n .map((b) => b.trim())\n .filter(Boolean);\n\n for (let i = 1; i <= TOTAL_STORAGE_NODES_COUNT; i++) {\n const exists = nodes.some((n) => n.id === i);\n if (!exists) {\n let fallbackBucketName = \"\";\n if (fallbackEnvList[i - 1]) {\n fallbackBucketName = fallbackEnvList[i - 1];\n } else if (i === 1 && baseBucket) {\n fallbackBucketName = baseBucket;\n } else if (DEFAULT_Z1_FALLBACK_BUCKETS[i - 1]) {\n fallbackBucketName = DEFAULT_Z1_FALLBACK_BUCKETS[i - 1];\n } else {\n fallbackBucketName = `mai-storage-${i}`;\n }\n\n const bucket = Deno.env.get(`S3_BUCKET_${i}`) ||\n Deno.env.get(`S3_BUCKET${i}`) ||\n Deno.env.get(`Z1_BUCKET_${i}`) ||\n Deno.env.get(`Z1_BUCKET${i}`) ||\n fallbackBucketName;\n\n const accessKeyId = Deno.env.get(`S3_ACCESS_KEY_ID_${i}`) ||\n Deno.env.get(`S3_ACCESS_KEY_ID${i}`) ||\n Deno.env.get(`Z1_ACCESS_KEY_ID_${i}`) ||\n Deno.env.get(`Z1_ACCESS_KEY_ID${i}`) ||\n baseAccessKey;\n\n const secretAccessKey = Deno.env.get(`S3_SECRET_ACCESS_KEY_${i}`) ||\n Deno.env.get(`S3_SECRET_ACCESS_KEY${i}`) ||\n Deno.env.get(`Z1_SECRET_ACCESS_KEY_${i}`) ||\n Deno.env.get(`Z1_SECRET_ACCESS_KEY${i}`) ||\n baseSecretKey;\n\n const rawEndpoint = Deno.env.get(`S3_ENDPOINT_${i}`) ||\n Deno.env.get(`S3_ENDPOINT${i}`) ||\n Deno.env.get(`Z1_ENDPOINT_${i}`) ||\n Deno.env.get(`Z1_ENDPOINT${i}`) ||\n baseEndpoint;\n const endpoint = cleanUrl(rawEndpoint);\n\n const region = Deno.env.get(`S3_REGION_${i}`) ||\n Deno.env.get(`S3_REGION${i}`) ||\n Deno.env.get(`Z1_REGION_${i}`) ||\n Deno.env.get(`Z1_REGION${i}`) ||\n baseRegion;\n\n const rawPublicUrl = Deno.env.get(`S3_PUBLIC_URL_${i}`) ||\n Deno.env.get(`S3_PUBLIC_URL${i}`) ||\n Deno.env.get(`Z1_PUBLIC_URL_${i}`) ||\n Deno.env.get(`Z1_PUBLIC_URL${i}`);\n\n let publicUrl = \"\";\n if (rawPublicUrl) {\n publicUrl = cleanUrl(rawPublicUrl);\n } else if (basePublicUrl) {\n publicUrl = `${cleanUrl(basePublicUrl)}/${bucket}`;\n } else {\n publicUrl = `${endpoint}/${bucket}`;\n }\n\n nodes.push({\n id: i,\n endpoint,\n region,\n accessKeyId,\n secretAccessKey,\n bucket,\n publicUrl,\n });\n }\n }\n }\n\n // Tri par ID croissant pour ordre déterministe\n nodes.sort((a, b) => a.id - b.id);\n return nodes;\n}\n\n/**\n * Retourne la liste ordonnée des nœuds de stockage pour le fallback.\n * Le nœud principal est placé en premier, suivi des autres buckets Z1 Storage en réserve (fallback).\n */\nexport function getFallbackNodes(primaryNode?: StorageNode): StorageNode[] {\n const allNodes = getStorageNodes();\n if (!primaryNode) return allNodes;\n const others = allNodes.filter((n) => n.id !== primaryNode.id);\n return [primaryNode, ...others];\n}\n\n/**\n * Effectue un upload S3 avec bascule automatique (fallback) sur les 10 nœuds/buckets\n * Z1 Storage configurés si le nœud principal échoue (erreur HTTP 4xx/5xx ou exception réseau).\n */\nexport async function uploadWithFallback(\n primaryNode: StorageNode,\n filePath: string,\n body: any,\n options: {\n contentType: string;\n acl?: string;\n },\n): Promise<{\n success: boolean;\n activeNode: StorageNode;\n publicUrl: string;\n error?: string;\n}> {\n const candidateNodes = getFallbackNodes(primaryNode);\n let lastError = \"\";\n\n for (const node of candidateNodes) {\n try {\n const s3Client = await buildS3Client(node);\n const uploadUrl = `${node.endpoint}/${node.bucket}/${filePath}`;\n const res = await s3Client.fetch(uploadUrl, {\n body,\n headers: {\n \"Content-Type\": options.contentType || \"application/octet-stream\",\n \"x-amz-acl\": options.acl || \"public-read\",\n },\n method: \"PUT\",\n });\n\n if (res.ok) {\n return {\n activeNode: node,\n publicUrl: `${node.publicUrl}/${filePath}`,\n success: true,\n };\n }\n\n lastError = await res.text().catch(() => `HTTP ${res.status}`);\n console.warn(\n `[Z1 Storage Fallback] Échec upload sur le bucket \"${node.bucket}\" (node ${node.id}, status ${res.status}): ${lastError}. Bascule sur le bucket suivant...`,\n );\n } catch (err: any) {\n lastError = err?.message || String(err);\n console.warn(\n `[Z1 Storage Fallback] Exception réseau sur le bucket \"${node.bucket}\" (node ${node.id}): ${lastError}. Bascule sur le bucket suivant...`,\n );\n }\n }\n\n return {\n activeNode: primaryNode,\n error: lastError,\n publicUrl: `${primaryNode.publicUrl}/${filePath}`,\n success: false,\n };\n}\n\n/**\n * Sélectionne un nœud de stockage dans le pool via un hachage déterministe (sharding équilibré).\n */\nexport function selectStorageNode(seed: string): StorageNode {\n const nodes = getStorageNodes();\n if (nodes.length <= 1) return nodes[0];\n\n let hash = 0;\n for (let i = 0; i < seed.length; i++) {\n hash = (hash << 5) - hash + seed.charCodeAt(i);\n hash |= 0; // Convertit en entier 32 bits\n }\n const index = Math.abs(hash) % nodes.length;\n return nodes[index];\n}\n\n/**\n * Retrouve le nœud de stockage et la clé brute d'un enregistrement existant.\n */\nexport function findStorageNodeForRecord(\n r2Key: string,\n fileUrl?: string,\n): { node: StorageNode; rawKey: string } {\n const nodes = getStorageNodes();\n\n // 1. Format explicite taggé : node-1:bucket-name:key-path\n if (r2Key && r2Key.startsWith(\"node-\")) {\n const parts = r2Key.split(\":\");\n if (parts.length >= 3) {\n const nodeId = parseInt(parts[0].replace(\"node-\", \"\"), 10);\n const found = nodes.find((n) => n.id === nodeId);\n if (found) {\n return { node: found, rawKey: parts.slice(2).join(\":\") };\n }\n }\n }\n\n // 2. Recherche par nom de bucket dans la clé ou l'URL\n for (const node of nodes) {\n if (r2Key && r2Key.startsWith(`${node.bucket}/`)) {\n return { node, rawKey: r2Key.slice(node.bucket.length + 1) };\n }\n if (\n fileUrl &&\n (fileUrl.includes(`/${node.bucket}/`) ||\n fileUrl.includes(`://${node.bucket}.`))\n ) {\n return { node, rawKey: r2Key };\n }\n }\n\n // 3. Fallback sur le premier nœud\n return { node: nodes[0], rawKey: r2Key };\n}\n\n/**\n * Crée un client S3 (compatible Z1 Storage / Cloudflare R2 / AWS S3) pour un nœud donné.\n */\nexport async function buildS3Client(node?: StorageNode) {\n const targetNode = node || getStorageNodes()[0];\n const { AwsClient } = await import(\"npm:aws4fetch\");\n return new AwsClient({\n accessKeyId: targetNode.accessKeyId,\n region: targetNode.region,\n secretAccessKey: targetNode.secretAccessKey,\n service: \"s3\",\n });\n}\n\n// Aliases de rétro-compatibilité\nexport const buildR2Client = buildS3Client;\nexport function getR2Endpoint(): string {\n return getStorageNodes()[0].endpoint;\n}\nexport function getR2Bucket(): string {\n return getStorageNodes()[0].bucket;\n}\nexport function getR2PublicBase(): string {\n return getStorageNodes()[0].publicUrl;\n}\n\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 à 10 buckets\n const primaryNode = selectStorageNode(`${userId}-${uniqueId}`);\n const arrayBuffer = await file.arrayBuffer();\n\n // Upload avec bascule automatique (fallback) sur les autres buckets du pool Z1 Storage\n const uploadResult = await uploadWithFallback(\n primaryNode,\n fileKey,\n arrayBuffer,\n {\n contentType: file.type || \"application/octet-stream\",\n acl: \"public-read\",\n },\n );\n\n if (!uploadResult.success) {\n console.error(\n \"Z1 Storage Upload Error (fallback épuisé):\",\n uploadResult.error,\n );\n return c.json(\n {\n error:\n \"Erreur lors de l'upload vers le stockage (tous les buckets en échec).\",\n },\n 500,\n );\n }\n\n const activeNode = uploadResult.activeNode;\n const storedKey = `node-${activeNode.id}:${activeNode.bucket}:${fileKey}`;\n const publicUrl = uploadResult.publicUrl;\n const mimeType = file.type || \"application/octet-stream\";\n\n // Insérer dans cloud_files\n const inserted = await sql`\n INSERT INTO cloud_files (user_id, filename, original_name, r2_key, url, size_bytes, mime_type)\n VALUES (${userId}::text, ${cleanFilename}, ${cleanOriginal}, ${storedKey}, ${publicUrl}, ${fileSize}, ${mimeType})\n RETURNING id, filename, original_name, url, size_bytes, mime_type, uploaded_at\n `;\n\n // Upsert cloud_storage_usage\n await sql`\n INSERT INTO cloud_storage_usage (user_id, bytes_used, files_count, updated_at)\n VALUES (${userId}::text, ${fileSize}, 1, NOW())\n ON CONFLICT (user_id)\n DO UPDATE SET\n bytes_used = cloud_storage_usage.bytes_used + ${fileSize},\n files_count = cloud_storage_usage.files_count + 1,\n updated_at = NOW()\n `;\n\n const newBytesUsed = bytesUsed + fileSize;\n const percentUsed = Math.round((newBytesUsed / bytesLimit) * 10_000) /\n 100;\n\n return c.json({\n file: inserted[0],\n percent_used: percentUsed,\n storage: {\n bytes_limit: bytesLimit,\n bytes_used: newBytesUsed,\n over_limit: newBytesUsed >= bytesLimit,\n percent_used: percentUsed,\n tier,\n },\n success: true,\n });\n } catch (err: any) {\n console.error(\"Cloud Upload Error:\", err);\n return c.json({ error: \"Erreur serveur lors de l'upload Cloud.\" }, 500);\n }\n };\n\n app.post(\"/cloud/upload\", handleCloudUpload);\n app.post(\"/v1/cloud/upload\", handleCloudUpload);\n app.post(\"/cloud/upload/\", handleCloudUpload);\n app.post(\"/v1/cloud/upload/\", handleCloudUpload);\n\n // DELETE /cloud/files/:id & /v1/cloud/files/:id — Suppression définitive d'un fichier\n const handleDeleteFile = async (c: any) => {\n try {\n const token = extractToken(c.req.raw);\n if (!token) {\n return c.json({ error: \"Non authentifié.\" }, 401);\n }\n\n const payload = await verifyToken(token);\n const userId = payload.sub as string;\n const fileId = c.req.param(\"id\");\n const sql = getDb();\n\n // Récupérer le fichier (vérification propriété)\n const fileRes = await sql`\n SELECT id, r2_key, url, size_bytes\n FROM cloud_files\n WHERE id = ${fileId}::uuid AND user_id = ${userId}::text\n LIMIT 1\n `;\n\n if (fileRes.length === 0) {\n return c.json({ error: \"Fichier introuvable ou accès refusé.\" }, 404);\n }\n\n const { r2_key, url, size_bytes } = fileRes[0];\n\n // Identifier le nœud et supprimer de Z1 Storage\n const { node, rawKey } = findStorageNodeForRecord(r2_key, url);\n const s3Client = await buildS3Client(node);\n const deleteUrl = `${node.endpoint}/${node.bucket}/${rawKey}`;\n\n try {\n const delRes = await s3Client.fetch(deleteUrl, { method: \"DELETE\" });\n if (!delRes.ok && (!r2_key || !r2_key.startsWith(\"node-\"))) {\n // Si suppression échoue sur nœud par défaut pour un ancien fichier, tenter sur les autres nœuds du pool\n for (const fallbackNode of getFallbackNodes(node).slice(1)) {\n try {\n const fbClient = await buildS3Client(fallbackNode);\n const fbUrl =\n `${fallbackNode.endpoint}/${fallbackNode.bucket}/${rawKey}`;\n await fbClient.fetch(fbUrl, { method: \"DELETE\" });\n } catch {}\n }\n }\n } catch (s3Err) {\n console.error(\"Z1 Delete Error (continuing anyway):\", s3Err);\n }\n\n // Supprimer de la base de données\n await sql`DELETE FROM cloud_files WHERE id = ${fileId}::uuid AND user_id = ${userId}::text`;\n\n // Décrémenter cloud_storage_usage\n await sql`\n UPDATE cloud_storage_usage\n SET\n bytes_used = GREATEST(0, bytes_used - ${size_bytes}),\n files_count = GREATEST(0, files_count - 1),\n updated_at = NOW()\n WHERE user_id = ${userId}::text\n `;\n\n return c.json({ id: fileId, success: true });\n } catch (err: any) {\n console.error(\"Cloud Delete Error:\", err);\n return c.json({ error: \"Erreur serveur lors de la suppression.\" }, 500);\n }\n };\n\n app.delete(\"/cloud/files/:id\", handleDeleteFile);\n app.delete(\"/v1/cloud/files/:id\", handleDeleteFile);\n}",[],[200],"1eac350f-e898-4086-8572-27fb95d00b7f","projects.ts","01a0439e-799b-71f2-9deb-8ad886d5692b",["D",1787840854427],"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}",[],[208],"b0b3ada1-c0ba-4a63-8e69-56befbc973c8","models.ts","01a0439e-799a-750e-99aa-caea4a67cc19",["D",1787840854427],"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}",[],[215],["D",1787840854427],[],[18],"aa3b9d98-7f2c-4049-b96f-132564c02425","maiModels.ts","01a0439e-799a-750e-99aa-c08cc7916a0c",["D",1787840854427],"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;",[],[225],"a33d10a5-a7b6-40ef-b7c7-66f0e34bd79b","images.ts","01a0439e-799a-750e-99aa-bc77aab64427",["D",1787840854427],"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}",[],[232],"08535abd-7833-4aa9-950b-77e92bce016b","email.ts","01a0439e-799a-750e-99aa-b8954c71d9d4",["D",1787840854427],"import nodemailer from \"npm:nodemailer\";\n\nfunction escapeHtml(str: string): string {\n return String(str)\n .replace(/&/g, \"&\")\n .replace(/</g, \"<\")\n .replace(/>/g, \">\")\n .replace(/\"/g, \""\")\n .replace(/'/g, \"'\");\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 <strong>mAI</strong> :\";\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 <strong>mAI</strong> :\";\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 <strong>${tierUnlocked}</strong> sur <strong>mAI</strong> !<br><br>\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).<br><br>\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 <strong>mAI</strong> a été détectée depuis :<br><br>\n <strong>Appareil :</strong> ${device}<br>\n <strong>Localisation :</strong> ${location}<br><br>\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 <!DOCTYPE html>\n <html>\n <head>\n <meta charset=\"utf-8\">\n <meta name=\"viewport\" content=\"width=device-width, initial-scale=1.0\">\n </head>\n <body style=\"margin:0; padding:0; background-color:#090d16; font-family:'Segoe UI', Roboto, Helvetica, Arial, sans-serif; color:#f8fafc;\">\n <div style=\"max-width:560px; margin:40px auto; background:#111827; border:1px solid #1f293d; border-radius:16px; overflow:hidden; box-shadow:0 20px 25px -5px rgba(0,0,0,0.5);\">\n \n \n <div style=\"background:linear-gradient(135deg, #1e1b4b 0%, #31104b 100%); padding:32px 24px; text-align:center; border-bottom:1px solid #2e1065;\">\n <img src=\"https://upload.fs.fr/azq3C6GLea.png\" alt=\"mAI Logo\" style=\"height:48px; width:auto; max-width:180px; object-fit:contain; display:inline-block;\" />\n <h1 style=\"color:#ffffff; font-size:20px; font-weight:700; margin:16px 0 0 0; letter-spacing:-0.5px;\">${title}</h1>\n </div>\n\n \n <div style=\"padding:32px 28px; line-height:1.6; font-size:15px; color:#cbd5e1;\">\n <p style=\"margin-top:0;\">Bonjour,</p>\n <p>${textContent}</p>\n \n ${\n showCode\n ? `\n \n <div style=\"background:#1e293b; border:1px solid #334155; border-radius:12px; padding:24px; text-align:center; margin:28px 0;\">\n <div style=\"font-size:34px; font-weight:800; letter-spacing:8px; color:#a855f7; font-family:Consolas, Monaco, monospace; margin-bottom:12px; user-select:all;\">\n ${escapeHtml(code)}\n </div>\n <p style=\"font-size:12px; color:#94a3b8; margin:0;\">Code unique • Expire dans 10 minutes</p>\n </div>\n `\n : \"\"\n }\n\n <p style=\"font-size:13px; color:#94a3b8; margin-top:28px;\">Si vous n'êtes pas à l'origine de cette demande, vous pouvez l'ignorer ou sécuriser votre compte.</p>\n </div>\n\n \n <div style=\"background-color:#0b0f19; padding:20px 24px; text-align:center; border-top:1px solid #1e293b; font-size:12px; color:#64748b;\">\n <p style=\"margin:0 0 6px 0;\">© 2026 mAI — Plateforme d'Intelligence Artificielle & APIs</p>\n <p style=\"margin:0;\">Cet e-mail automatique a été envoyé de manière sécurisée.</p>\n </div>\n\n </div>\n </body>\n </html>\n `;\n\n // 1. Envoi via Google Apps Script (Recommandé)\n const googleScriptsUrl = Deno.env.get(\"GOOGLE_SCRIPTS_URL\") ||\n Deno.env.get(\"GOOGLE_SCRIPT_URL\");\n const googleScriptSecret = Deno.env.get(\"GOOGLE_SCRIPTS_SECRET\") ||\n Deno.env.get(\"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: email,\n subject: 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 = email.replace(/(.{2}).*(@.*)/, \"$1***$2\");\n console.log(`[EMAIL] Google Apps Script OK to=${maskedTo}`);\n return;\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 } else {\n console.warn(\n \"[EMAIL] GOOGLE_SCRIPTS_URL/GOOGLE_SCRIPT_SECRET non configurés — fallback SMTP\",\n );\n }\n\n // 2. Fallback Gmail SMTP via Nodemailer\n const gmailUser = Deno.env.get(\"GMAIL_USER\");\n const gmailAppPass = Deno.env.get(\"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\" <${gmailUser}>`,\n html,\n subject,\n to: email,\n });\n\n const maskedTo = email.replace(/(.{2}).*(@.*)/, \"$1***$2\");\n console.log(`[EMAIL] Gmail SMTP OK to=${maskedTo}`);\n return;\n } catch (err: any) {\n console.error(\"Erreur envoi Gmail SMTP :\", err?.message || err);\n }\n } else {\n console.warn(\n \"[EMAIL] GMAIL_USER/GMAIL_APP_PASSWORD non configurés — aucun moyen d'envoi disponible\",\n );\n }\n}",[],[239],"c8d0aba6-499f-495f-b920-578b79743a38","devices.ts","01a0439e-799a-750e-99aa-b5f9771535b9",["D",1787840854427],"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}",[],[246],"2ec055c0-ffd6-4691-b9d5-a6edba80c4a3","config.ts","01a0439e-799a-750e-99aa-b2bd53a0ca7a",["D",1787840854427],"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 };",[],[253],"1240acf6-67e0-47c5-8669-84e4ccc73781","auth.ts","01a0439e-799a-750e-99aa-ac05dc03f291",["D",1787840854427],"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}",[],[260],"291abac1-14a8-4dd0-84a5-7e6c71132df2","audio.ts","01a0439e-799a-750e-99aa-a8f317609c6f",["D",1787840854427],"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}",[],[267],"4611bd84-4724-4cfa-8b5b-c4a47c004379","api-middleware.ts","01a0439e-799a-750e-99aa-a415fab37763",["D",1787840854427],"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}",[],[274],["D",1785339526786],["D",1789474235934],{"_11":12,"_129":73},{"_11":12,"_124":125,"_72":73,"_30":71,"_126":127,"_128":24},{"_38":114,"_13":16,"_32":35,"_115":75,"_116":62,"_117":118,"_119":79,"_120":75,"_121":41,"_122":14,"_123":12},"ctx",{"_51":-5,"_149":318,"_319":320,"_321":322,"_323":24,"_324":24,"_325":24,"_326":88,"_327":-5,"_328":-7,"_329":-7,"_330":26,"_331":24,"_332":24,"_333":-5,"_334":24,"_335":24,"_336":24,"_337":-5},"ENV",{"_289":290,"_291":292,"_293":63,"_294":295,"_296":297,"_298":299,"_300":301,"_302":303,"_304":305,"_306":307,"_308":309,"_310":311,"_312":313,"_314":315,"_316":317},"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>

History · main.ts