${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","deleted","label",[112],"pulls","branches",1,"forks","envVars",{"_136":138,"_139":40},"connections",{"_136":40,"_137":40},"count","unfilledCount",14,"emptyCount",{"_18":111,"_20":112,"_113":114,"_115":-5,"_116":69,"_117":67,"_118":105,"_22":141,"_66":120,"_121":122,"_123":124,"_125":26,"_126":-5,"_142":143,"_87":144},["D",1781538574399],"children",[],[112],["D",1779121172764],["D",1789534872841],{"_16":17,"_85":81},{"_16":17,"_78":79,"_80":81,"_33":34,"_82":83,"_84":26},{"_66":67,"_20":68,"_18":69,"_70":19,"_71":-5,"_72":-5,"_73":-5,"_74":-5,"_75":-5,"_76":21,"_77":17},"ctx",{"_59":-5,"_107":183,"_184":185,"_186":187,"_188":26,"_189":26,"_190":26,"_191":105,"_192":-5,"_193":-7,"_194":-7,"_195":40,"_196":26,"_197":26,"_198":-5,"_199":26,"_200":26,"_201":26,"_202":-5},"ENV",{"_154":155,"_156":157,"_158":68,"_159":160,"_161":162,"_163":164,"_165":166,"_167":168,"_169":170,"_171":172,"_173":174,"_175":176,"_177":178,"_179":180,"_181":182},"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"]

Search