${icon}

${title}

${itLine}

${enLine}

— Pasquale · Grazie Pasquale

`;\n}\n\nexport default async function (req: Request): Promise {\n const url = new URL(req.url);\n\n // Pages de confirmation / annulation de paiement (cibles success_url / cancel_url de Stripe).\n if (req.method === \"GET\" && (url.pathname.endsWith(\"/merci\") || url.pathname.endsWith(\"/annule\"))) {\n return new Response(paymentPage(url.pathname.endsWith(\"/merci\")), {\n status: 200,\n headers: { \"content-type\": \"text/html; charset=utf-8\" },\n });\n }\n\n // --- Validation du webhook par Meta ---\n if (req.method === \"GET\") {\n const challenge = url.searchParams.get(\"hub.challenge\");\n return new Response(challenge ?? \"\", { status: 200 });\n }\n\n // Endpoints admin : simulation de l'acceptation prestataire / du paiement.\n if (req.method === \"POST\" && url.pathname.endsWith(\"/admin/confirm-driver\")) {\n return await handleConfirmDriver(req);\n }\n if (req.method === \"POST\" && url.pathname.endsWith(\"/admin/confirm-payment\")) {\n return await handleConfirmPayment(req);\n }\n if (req.method === \"POST\" && url.pathname.endsWith(\"/admin/simulate\")) {\n return await handleSimulate(req);\n }\n if (req.method === \"POST\" && url.pathname.endsWith(\"/admin/price-test\")) {\n return await handlePriceTest(req);\n }\n\n // Webhook Stripe (paiement confirmé -> révélation du contact).\n if (req.method === \"POST\" && url.pathname.endsWith(\"/stripe/webhook\")) {\n return await handleStripeWebhook(req);\n }\n\n if (req.method !== \"POST\") {\n return new Response(\"Method not allowed\", { status: 405 });\n }\n\n // --- Reception d'un event WhatsApp ---\n let payload: any = null;\n try {\n payload = await req.json();\n } catch {\n return new Response(\"OK\", { status: 200 });\n }\n\n const value = payload?.entry?.[0]?.changes?.[0]?.value;\n const message = value?.messages?.[0];\n\n // Pas de message reel (accuse de lecture/livraison) -> on ignore.\n if (!message) {\n return new Response(\"OK (no message)\", { status: 200 });\n }\n\n const from = message.from ?? \"\";\n const text = extractText(message);\n const messageId = message.id ?? \"\";\n const guestName = value?.contacts?.[0]?.profile?.name ?? \"\";\n\n // Rien d'exploitable -> on accuse reception.\n if (!from || !text) {\n return new Response(\"OK (empty)\", { status: 200 });\n }\n\n try {\n await initDb();\n\n // Anti-duplication (retries Meta).\n if (await alreadyProcessed(messageId)) {\n return new Response(\"OK (duplicate)\", { status: 200 });\n }\n\n // Commandes secrètes (le texte de la commande n'est jamais sauvegardé dans l'historique).\n const cmd = text.trim().toLowerCase();\n if (cmd === \"/reset\") {\n await sqlite.execute({ sql: \"DELETE FROM messages WHERE phone = ?\", args: [from] });\n await sendWelcome(from); // repart de zéro avec le message d'accueil\n return new Response(\"OK (reset)\", { status: 200 });\n }\n // /retour : Benoît enregistre un feedback sur la conversation en cours.\n if (from === OWNER_PHONE && cmd.startsWith(\"/retour\")) {\n const comment = text.trim().slice(\"/retour\".length).trim();\n const snapshot = await loadHistory(from); // la conversation visée par le retour\n await sqlite.execute({\n sql: \"INSERT INTO feedback (phone, comment, context, created_at, resolved) VALUES (?, ?, ?, ?, 0)\",\n args: [from, comment || \"(sans commentaire)\", JSON.stringify(snapshot), Date.now()],\n });\n await sendWhatsApp(\n from,\n \"📝 Retour bien noté, merci ! Je l'ai enregistré avec le contexte de la conversation.\",\n );\n return new Response(\"OK (retour)\", { status: 200 });\n }\n\n // Commandes de TEST réservées au numéro propriétaire (simulent les events externes).\n if (from === OWNER_PHONE && cmd === \"/trouve\") {\n await confirmDriverFor(from); // Marco accepte -> annonce + narratif de confiance\n return new Response(\"OK (trouve)\", { status: 200 });\n }\n if (from === OWNER_PHONE && cmd === \"/paye\") {\n await confirmPaymentFor(from); // paiement reçu -> révèle le contact\n return new Response(\"OK (paye)\", { status: 200 });\n }\n\n // Affiche \"en train d'écrire\" + marque le message lu (illusion d'un humain).\n await sendTyping(messageId);\n\n // Sauvegarde le message entrant.\n await saveMessage(from, \"user\", text);\n const myId = await latestUserMessageId(from);\n\n // REGROUPEMENT DES RAFALES : le guest envoie souvent plusieurs petits messages\n // d'affilée. On attend une courte fenêtre ; si un message plus récent arrive\n // pendant l'attente, CETTE invocation s'efface (l'invocation du dernier message\n // de la rafale répondra à tout) => une seule réponse qui voit toute la rafale.\n await sleep(BURST_WINDOW_MS);\n if ((await latestUserMessageId(from)) !== myId) {\n return new Response(\"OK (regroupé)\", { status: 200 });\n }\n\n // Dernier message de la rafale : on rafraîchit \"en train d'écrire\", puis on relit\n // l'historique complet (il contient désormais tous les messages de la rafale).\n await sendTyping(messageId);\n const history = await loadHistory(from);\n\n // Contexte dynamique : date + catalogue.\n const tarifs = await fetchTarifs();\n let dynamicContext = `${todayContext()}\\n\\n${buildCatalogText(tarifs)}`;\n\n // Premier contact d'un nouveau numéro (ex : flash du QR code en masseria) :\n // l'accueil premium est déclenché DANS cette réponse, sans ignorer le message du guest.\n if (history.length > 0 && history.every((m) => m.role === \"user\")) dynamicContext += firstContactDirective();\n\n // La fenêtre de regroupement ci-dessus joue déjà le rôle de délai \"humain\".\n const replyRaw = await callClaude(dynamicContext, history, tarifs, from, guestName);\n let reply = replyRaw;\n if (!reply) reply = \"Désolé, je n'ai pas bien saisi — pouvez-vous reformuler ? 🙏\";\n\n // Sauvegarde + envoi.\n await saveMessage(from, \"assistant\", reply);\n await sendWhatsApp(from, reply);\n } catch (e) {\n console.error(\"Handler error:\", e);\n await sendWhatsApp(\n from,\n \"Veuillez m'excuser, un petit souci technique de mon côté 🙏 Pouvez-vous réessayer dans un instant ?\",\n ).catch(() => {});\n }\n\n return new Response(\"OK\", { status: 200 });\n}\n","label",[59],"pulls","branches","forks","envVars",{"_166":168,"_169":88},"connections",{"_166":88,"_167":88},"count","unfilledCount",14,"emptyCount",{"_28":150,"_13":59,"_57":58,"_38":-5,"_30":31,"_151":111,"_152":144,"_32":171,"_34":154,"_60":61,"_155":156,"_62":24,"_157":-5,"_172":173,"_126":174},["D",1781538574399],"children",[],[59],["D",1779121172764],["D",1789534872841],{"_11":12,"_125":65},{"_11":12,"_120":121,"_64":65,"_25":63,"_122":123,"_124":24},{"_34":111,"_13":16,"_28":31,"_112":73,"_113":-5,"_114":-5,"_115":-5,"_116":-5,"_117":-5,"_118":14,"_119":12},"ctx",{"_46":-5,"_146":213,"_214":215,"_216":217,"_218":24,"_219":24,"_220":24,"_221":144,"_222":-5,"_223":-7,"_224":-7,"_225":88,"_226":24,"_227":24,"_228":-5,"_229":24,"_230":24,"_231":24,"_232":-5},"ENV",{"_184":185,"_186":187,"_188":16,"_189":190,"_191":192,"_193":194,"_195":196,"_197":198,"_199":200,"_201":202,"_203":204,"_205":206,"_207":208,"_209":210,"_211":212},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","fdb67791413f4386b4dbf18f354029a617f6160f","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"]