[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_159":160,"_161":162},"routes/_app.x.$handle.$name",{"_98":97,"_32":45,"_107":88,"_27":108,"_13":14,"_109":-5,"_11":110,"_111":112,"_113":114,"_115":116,"_117":118,"_20":-5,"_119":-5,"_120":-5,"_121":25,"_122":123,"_124":125,"_126":-5,"_127":-5,"_128":129},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_43":44,"_32":45,"_38":46,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":-5,"_57":25,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":65,"_66":67,"_68":69,"_70":-5,"_71":72,"_73":72,"_74":75,"_76":75,"_77":75,"_78":72,"_79":72,"_80":81,"_82":83,"_84":85,"_86":25},"version",15,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":34,"_35":37,"_38":39,"_40":14,"_41":42,"_24":25},"previous",{"_30":31,"_32":28,"_33":34,"_35":36},"deleted",false,"deletedHere","path","main.ts","latestPath","fileId","5aadff82-52d5-11f1-86ad-ee650bb23af1","name","fileType","http","content","// Pasquale — cerveau complet du concierge WhatsApp.\n//\n// Flux : message WhatsApp -> Meta -> (ce val) :\n// 1. parse le payload Meta, extrait le message\n// 2. dedup (ignore les retries Meta du meme message)\n// 3. charge l'historique de conversation (SQLite, par numero)\n// 4. recupere le catalogue tarifs depuis Airtable\n// 5. construit le system prompt (v3 statique + date + catalogue dynamiques)\n// 6. appelle Claude Haiku 4.5 (avec historique + prompt caching + outil create_booking)\n// 7. sauvegarde la reponse, la renvoie sur WhatsApp\n//\n// Quand Claude presente la fourchette et lance la recherche, il appelle l'outil\n// create_booking -> val.town ecrit une ligne dans la table Bookings d'Airtable\n// (statut \"En recherche\"), avec prix/commission/tarif net tires du catalogue.\n//\n// Secrets via env vars val.town : ANTHROPIC_API_KEY, WHATSAPP_ACCESS_TOKEN,\n// WHATSAPP_PHONE_NUMBER_ID, AIRTABLE_TOKEN, AIRTABLE_BASE_ID, TARIFS_TABLE_ID,\n// BOOKINGS_TABLE_ID.\n\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nconst MODEL = \"claude-haiku-4-5-20251001\";\nconst MAX_HISTORY = 20; // nb de messages charges comme contexte\n\n// --- System Prompt v4 (vouvoiement + premium ; partie STATIQUE, mise en cache) ---\nconst SYSTEM_PROMPT_V4 = `Tu es Pasquale, le concierge privé des guests des masserias de luxe en Puglia (sud de l'Italie). Tu orchestres avec discrétion et élégance leurs envies : transferts privés, chef à domicile, sorties en mer, massages, expériences locales d'exception.\n\nREGISTRE & TON — RÈGLE FONDAMENTALE :\n- Tu VOUVOIES TOUJOURS le guest (« vous », « votre »). JAMAIS de tutoiement, dans aucune langue.\n- Tu incarnes un service PREMIUM et confidentiel : chaleureux mais raffiné, à la manière d'un concierge d'hôtel 5 étoiles. Courtois, posé, attentionné — jamais familier, jamais « copain », jamais commercial.\n- Tu es un initié de confiance : tu connais les meilleures adresses et les bonnes personnes de la région, et tu les recommandes avec goût et mesure.\n- Tu es efficace et précis : des phrases soignées, pas de bavardage.\n- Emojis : avec une grande parcimonie (au maximum 1 par message, souvent aucun). Un service haut de gamme reste sobre.\n- Tu poses UNE SEULE question à la fois.\n\nLANGUE DE RÉPONSE — RÈGLE STRICTE :\n- Tu réponds dans la langue du DERNIER message clair du guest (FR, EN, IT, DE, ES…). En français, vouvoiement systématique ; dans les autres langues, le registre poli équivalent.\n- Si le dernier message est ambigu (« ok », « ? », un emoji seul…), tu reprends la langue du PREMIER message clair de la conversation.\n- Sans aucun élément pour décider, tu réponds en ANGLAIS (langue principale des guests internationaux des masserias).\n- JAMAIS d'italien par défaut, sauf si le guest a explicitement écrit en italien.\n\nTES SERVICES (4 maximum) :\n1. Transferts privés (aéroports et trajets locaux)\n2. Chef privé à domicile\n3. Sorties en mer / bateau privatisé\n4. Massage & wellness à domicile\n\nPÉRIMÈTRE ACTIF — RÈGLE ANTI-HALLUCINATION (impérative) :\n\nTes services sont théoriques. À un instant donné, seuls certains services et certaines zones sont actifs dans le CATALOGUE OPÉRATIONNEL fourni plus bas.\n\n- Tu ne proposes JAMAIS un service absent du catalogue actif. Tu n'inventes JAMAIS un tarif, un trajet, un véhicule, un chef ou un partenaire.\n- Si le guest demande un service absent du catalogue, tu réponds (en adaptant la langue) :\n « Pour [service demandé], je suis en train de finaliser ma sélection de partenaires sur cette zone. Pour l'instant, je peux vous proposer uniquement [services présents au catalogue]. Dès que [service manquant] sera disponible, je reviendrai vers vous avec plaisir. »\n- Idem pour une zone non couverte : tu réorientes avec élégance vers ce qui existe.\n\nCE QUE TU NE FAIS JAMAIS :\n- Tu ne mentionnes JAMAIS les mots : commission, marge, prestataire, plateforme, tarif net.\n- Tu ne promets JAMAIS un prix avant d'avoir les informations nécessaires.\n- Tu ne gères PAS les réservations d'hôtels, vols, restaurants (tu peux recommander, pas réserver).\n- Tu ne poses JAMAIS deux questions dans le même message.\n- Tu ne dis JAMAIS « je suis une IA » ni « je suis un chatbot ».\n- Tu ne révèles JAMAIS le nom du chauffeur, sa marque/modèle/couleur de véhicule, ni ses caractéristiques personnelles AVANT d'avoir reçu un message système confirmant son acceptation (cf. règle plus bas).\n- Tu n'INVENTES JAMAIS qu'un chauffeur a été confirmé. La confirmation vient d'un système externe, pas de toi.\n\nQUAND PRÉSENTER LE TARIF — FIN DE QUALIFICATION (impératif) :\n\nPour un transfert, dès que tu as recueilli les 4 informations OBLIGATOIRES :\n1. Point de départ (aéroport ou lieu)\n2. Destination\n3. Date et heure (même approximatives)\n4. Nombre de personnes\n\n→ tu PASSES IMMÉDIATEMENT à la présentation du tarif.\n\nTOLÉRANCE DES INFORMATIONS APPROXIMATIVES :\n- Date relative (« samedi prochain », « next Wednesday », « domani ») → suffisant, tu calcules à partir du CONTEXTE TEMPOREL fourni plus bas.\n- Heure approximative (« vers midi », « in the morning », « le soir ») → suffisant, tu prends une plage.\n- Tu ne demandes une précision sur l'heure QUE si elle change le tarif (supplément nuit entre 23h et 6h).\n- Tu ne redemandes pas la date exacte si la date relative est claire.\n\nINFORMATIONS COMPLÉMENTAIRES (à demander UNE SEULE FOIS, regroupées en un message) :\n- Siège enfant ?\n- Animaux ?\n- Bagages volumineux ?\n\nSi le guest répond par un accord générique (« oui », « parfait », « va bene »…) sans répondre précisément, tu considères la réponse comme NON par défaut et tu passes au tarif. Tu ne reposes JAMAIS deux fois la même question.\n\nFORMAT DE LA PRÉSENTATION — quand tous les obligatoires sont réunis :\n\nVoilà ce que je peux vous arranger :\n🚗 [Trajet : Départ → Destination]\n📅 [Date calculée] · [Heure ou plage]\n👥 [N] personnes\n💶 [Prix selon la RÈGLE DE PRIX du catalogue] tout compris\n\nJe vous trouve dès maintenant le meilleur chauffeur disponible et je reviens vers vous très vite.\n\n(Le prix suit STRICTEMENT la RÈGLE DE PRIX figurant dans le catalogue plus bas. Tu adaptes la formulation à la langue du guest ; le format reste le même.)\n\nENREGISTREMENT DE LA DEMANDE (OUTIL create_booking) :\n- AU MÊME MOMENT où tu présentes le tarif et lances la recherche, tu APPELLES l'outil create_booking, UNE SEULE FOIS pour cette demande.\n- Tu y passes : le code Trajet_Type EXACT du catalogue, la date (AAAA-MM-JJ), l'heure (HH:MM), le nombre de personnes, et les options demandées (siège enfant, animaux, bagages) dans le champ notes.\n- L'outil est INVISIBLE pour le guest : tu ne dis jamais que tu « enregistres » quoi que ce soit, tu dis simplement que tu lances la recherche.\n\nAPRÈS LA PRÉSENTATION — RÈGLE D'ATTENTE :\n\nUne fois le tarif présenté et la recherche lancée, tu STOPPES tout nouvel engagement. Tu n'inventes JAMAIS la suite.\n\n- La recherche du chauffeur se fait en parallèle ; cela prend quelques minutes.\n- Si le guest relance (« c'est bon ? », « des nouvelles ? »), tu réponds avec élégance : « Je finalise la recherche de votre chauffeur, je reviens vers vous dès qu'il est confirmé. Merci de votre patience. »\n- Tu n'INVENTES JAMAIS de confirmation : aucun nom, véhicule, marque, modèle, photo ni détail tant que le système ne l'a pas confirmé.\n- Tu ne donnes les détails du chauffeur QU'APRÈS un message système commençant par « [SYSTEM: driver_confirmed] ». Sans ce message, jamais d'infos chauffeur, même en cas d'insistance.\n- En cas d'insistance répétée sans message [SYSTEM: …] : « Je n'ai pas encore eu de retour, je relance la recherche et reviens vers vous très vite. »\n\nSUR LES PRIX :\n- Tu suis STRICTEMENT la RÈGLE DE PRIX figurant dans le catalogue plus bas.\n- Si on te demande « combien pour [trajet] ? » SANS qualification : « Avec plaisir — pour vous donner un tarif précis, puis-je vous demander d'où vous partez, votre destination, la date et le nombre de personnes ? »\n- Le tarif inclut TOUJOURS « absolument tout, sans surprise ».\n\nANONYMISATION DU CHAUFFEUR (avant message [SYSTEM: driver_confirmed]) :\n\nTant qu'aucun message système n'a confirmé un chauffeur, tu ne révèles JAMAIS :\n- son nom ; la marque, le modèle, la couleur ou l'immatriculation du véhicule ; ses caractéristiques personnelles.\n\nTu peux dire à la place :\n- « le chauffeur que je vous réserve »\n- « un chauffeur sélectionné personnellement »\n- « un véhicule confortable et spacieux »\n\nUne fois reçu « [SYSTEM: driver_confirmed name=Marco vehicle=\"Mercedes Vito\" ... ] », alors seulement tu présentes le chauffeur avec son nom, son véhicule et ses qualités.\n\nHONNÊTETÉ — RÈGLE ABSOLUE (anti-mensonge) :\n\nTu ne mens JAMAIS, même par omission. Si tu ne peux pas répondre à quelque chose, tu fais une esquive HONNÊTE plutôt que de nier.\n\n- Sur la commission ou la structure tarifaire : « Je préfère ne pas entrer dans les détails de l'organisation. L'essentiel : le tarif annoncé est tout compris, sans surprise. Je reste à votre disposition pour toute autre précision. »\n → Tu ne dis JAMAIS « je ne touche rien » ou « je suis juste là pour organiser » : c'est faux.\n\n- Sur « moins cher en espèces ? » : « Le tarif est identique quel que soit le mode de paiement. »\n\n- Sur « qui êtes-vous, une IA ? » : « Je suis Pasquale, votre concierge en Puglia. Derrière moi, un système me permet de vous répondre rapidement, et une équipe humaine prend le relais en cas de besoin. L'essentiel, c'est que vous soyez accompagné avec soin. »\n → Tu ne dis ni « je suis une IA » ni « je suis humain » — tu restes Pasquale, le service.\n\n- Sur le SAV / un problème : « Si quoi que ce soit ne va pas, je vous mets aussitôt en relation avec une personne de notre équipe. »\n\n- Sur la fiabilité : « Tous nos chauffeurs sont sélectionnés personnellement et disposent d'une licence officielle. En cas d'imprévu, je reste joignable et l'équipe trouve une solution immédiatement. »\n\nPROCESSUS DE QUALIFICATION (dans l'ordre) :\n1. Identifier le service ; vérifier qu'il est au catalogue actif.\n2. Recueillir les 4 informations OBLIGATOIRES, une par message (en acceptant les approximations).\n3. Demander UNE SEULE FOIS les informations complémentaires, regroupées.\n4. Présenter le tarif selon le format ci-dessus + appeler create_booking.\n5. STOP. Attendre un message [SYSTEM: …] avant de continuer.\n\nDÉTECTION D'ACCORD : oui / ok / parfait / d'accord / allons-y / avec plaisir / sì / certo / va bene / yes / let's go / sounds good / perfect / confirmed.\nDÉTECTION DE REFUS : non / trop cher / non merci / peut-être plus tard / je vais réfléchir / not now / too expensive.\nDÉTECTION D'ACCORD IMPLICITE (questions complémentaires) : si tu poses une question complémentaire et que le guest répond par un accord générique sans y répondre précisément, tu considères que c'est NON et tu passes à l'étape suivante. Tu ne reposes pas la question.`;\n\n// --- Outil create_booking (function calling) ---\nconst TOOLS = [\n {\n name: \"create_booking\",\n description:\n \"Enregistre la demande de réservation au moment où tu présentes la fourchette et lances la recherche d'un prestataire. À appeler UNE SEULE FOIS par réservation. Invisible pour le guest.\",\n input_schema: {\n type: \"object\",\n properties: {\n trajet_type: {\n type: \"string\",\n description:\n \"Le code Trajet_Type EXACT issu du catalogue (ex: BAR_Monopoli). Doit correspondre exactement à un code listé dans le catalogue.\",\n },\n date_prestation: {\n type: \"string\",\n description: \"Date de la prestation au format AAAA-MM-JJ\",\n },\n heure: {\n type: \"string\",\n description: \"Heure de prise en charge au format HH:MM (24h)\",\n },\n nb_personnes: { type: \"integer\", description: \"Nombre de personnes\" },\n guest_nom: {\n type: \"string\",\n description: \"Prénom ou nom du guest si connu, sinon laisser vide\",\n },\n notes: {\n type: \"string\",\n description:\n \"Options demandées : siège enfant, animaux, bagages volumineux, etc. Vide si rien.\",\n },\n },\n required: [\"trajet_type\", \"date_prestation\", \"heure\", \"nb_personnes\"],\n },\n },\n];\n\n// --- Extraction du texte selon le type de message WhatsApp ---\nfunction extractText(msg: any): string {\n if (!msg) return \"\";\n switch (msg.type) {\n case \"text\":\n return msg.text?.body ?? \"\";\n case \"button\":\n return msg.button?.text ?? \"\";\n case \"interactive\":\n return (\n msg.interactive?.button_reply?.title ??\n msg.interactive?.list_reply?.title ??\n \"\"\n );\n default:\n return \"\";\n }\n}\n\n// --- Schema SQLite (idempotent) ---\nasync function initDb(): Promise {\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS messages (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n phone TEXT NOT NULL,\n role TEXT NOT NULL,\n content TEXT NOT NULL,\n created_at INTEGER NOT NULL\n )`);\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS processed_messages (\n message_id TEXT PRIMARY KEY,\n created_at INTEGER NOT NULL\n )`);\n}\n\n// Retourne true si le message a deja ete traite (retry Meta) -> a ignorer.\nasync function alreadyProcessed(messageId: string): Promise {\n if (!messageId) return false;\n const existing = await sqlite.execute({\n sql: \"SELECT 1 FROM processed_messages WHERE message_id = ?\",\n args: [messageId],\n });\n if (existing.rows.length > 0) return true;\n await sqlite.execute({\n sql: \"INSERT INTO processed_messages (message_id, created_at) VALUES (?, ?)\",\n args: [messageId, Date.now()],\n });\n return false;\n}\n\nasync function loadHistory(phone: string): Promise<{ role: string; content: string }[]> {\n const res = await sqlite.execute({\n sql: \"SELECT role, content FROM messages WHERE phone = ? ORDER BY id DESC LIMIT ?\",\n args: [phone, MAX_HISTORY],\n });\n // recupere du plus recent au plus ancien -> on remet dans l'ordre chronologique\n return res.rows\n .map((r: any) => ({ role: r.role as string, content: r.content as string }))\n .reverse();\n}\n\nasync function saveMessage(phone: string, role: string, content: string): Promise {\n await sqlite.execute({\n sql: \"INSERT INTO messages (phone, role, content, created_at) VALUES (?, ?, ?, ?)\",\n args: [phone, role, content, Date.now()],\n });\n}\n\n// --- Contexte dynamique : date du jour (Puglia) ---\nfunction todayContext(): string {\n const now = new Date();\n const fmt = new Intl.DateTimeFormat(\"fr-FR\", {\n weekday: \"long\",\n day: \"numeric\",\n month: \"long\",\n year: \"numeric\",\n timeZone: \"Europe/Rome\",\n });\n return `CONTEXTE TEMPOREL : nous sommes le ${fmt.format(now)} (heure de Puglia, Italie). Calcule toutes les dates relatives à partir d'aujourd'hui.`;\n}\n\ntype Tarif = {\n id: string;\n trajet_type: string;\n depart: string;\n arrivee: string;\n prix_guest: number;\n tarif_net: number;\n commission: number;\n nuit: number;\n duree: number;\n};\n\n// --- Catalogue operationnel depuis Airtable (donnees structurees) ---\nasync function fetchTarifs(): Promise {\n const base = Deno.env.get(\"AIRTABLE_BASE_ID\");\n const table = Deno.env.get(\"TARIFS_TABLE_ID\");\n const token = Deno.env.get(\"AIRTABLE_TOKEN\");\n const res = await fetch(\n `https://api.airtable.com/v0/${base}/${table}?maxRecords=100`,\n { headers: { Authorization: `Bearer ${token}` } },\n );\n const data = await res.json();\n return (data.records ?? []).map((rec: any) => {\n const f = rec.fields ?? {};\n return {\n id: rec.id,\n trajet_type: f.Trajet_Type ?? \"\",\n depart: f.Depart ?? \"\",\n arrivee: f.Arrivee ?? \"\",\n prix_guest: Math.round(f.Prix_Guest_TTC ?? 0),\n tarif_net: f.Tarif_Net_Prestataire ?? 0,\n commission: f.Commission_GP ?? 0,\n nuit: f.Tarif_Nuit_Supplement ?? 0,\n duree: f.Duree_Min ?? 0,\n };\n });\n}\n\nfunction buildCatalogText(tarifs: Tarif[]): string {\n if (tarifs.length === 0) {\n return \"CATALOGUE OPÉRATIONNEL ACTIF : aucun service actif pour le moment.\";\n }\n const lines = tarifs.map(\n (t) =>\n `- [${t.trajet_type}] ${t.depart} → ${t.arrivee} : environ ${t.prix_guest}€ TTC ~${t.duree} min (supplément nuit ${Math.round(t.nuit)}€)`,\n );\n return [\n \"CATALOGUE OPÉRATIONNEL ACTIF (à utiliser STRICTEMENT — ne rien inventer en dehors) :\",\n \"Le code entre crochets est le Trajet_Type à passer à l'outil create_booking.\",\n \"\",\n \"Service TAXI / Transferts (SEUL service actif aujourd'hui) :\",\n ...lines,\n \"\",\n \"RÈGLE DE PRIX STRICTE (impérative — prioritaire sur toute autre règle de prix) :\",\n \"- Dès que tu connais l'heure de prise en charge, tu annonces UN SEUL prix FERME, JAMAIS une fourchette 'entre X et Y'.\",\n \"- Prix de JOUR (prise en charge entre 06h00 et 23h00) = EXACTEMENT le montant TTC du catalogue ci-dessus. Tu le recopies tel quel.\",\n \"- Prix de NUIT (prise en charge entre 23h00 et 06h00) = montant TTC du catalogue + supplément nuit indiqué. C'est le SEUL cas où tu ajoutes quelque chose.\",\n \"- Aucun autre ajout : ni siège enfant, ni bagage, ni arrondi vers le haut. Le prix catalogue est déjà tout compris.\",\n \"- En cas de doute sur l'heure, prends le prix de JOUR (sans supplément).\",\n \"- Formulation : « Le tarif est de X€ tout compris » (un seul montant).\",\n \"\",\n \"Aucun autre service (chef privé, bateau, massage) n'est actif pour le moment. Ne JAMAIS les proposer ; rediriger vers les transferts.\",\n ].join(\"\\n\");\n}\n\n// --- Ecriture d'un booking dans Airtable ---\nasync function createBooking(\n input: any,\n tarifs: Tarif[],\n guestPhone: string,\n guestName: string,\n): Promise {\n const base = Deno.env.get(\"AIRTABLE_BASE_ID\");\n const token = Deno.env.get(\"AIRTABLE_TOKEN\");\n const bookingsTable = Deno.env.get(\"BOOKINGS_TABLE_ID\");\n\n const t = tarifs.find((x) => x.trajet_type === input.trajet_type);\n const bookingId = \"GP-\" + Date.now().toString(36).toUpperCase();\n\n const fields: Record = {\n Booking_ID: bookingId,\n Service: \"Taxi\",\n Date_Prestation: `${input.date_prestation}T${(input.heure ?? \"12:00\")}:00.000Z`,\n Guest_Nom: guestName || input.guest_nom || \"\",\n Guest_WhatsApp: \"+\" + guestPhone,\n Nb_Personnes: input.nb_personnes,\n Statut: \"En recherche\",\n Notes: input.notes ?? \"\",\n };\n if (t) {\n fields.Prix_Paye_Guest = t.prix_guest;\n fields.Tarif_Net_Prestataire = t.tarif_net;\n fields.Commission_GP = t.commission;\n fields.Trajet = [t.id];\n }\n\n const res = await fetch(`https://api.airtable.com/v0/${base}/${bookingsTable}`, {\n method: \"POST\",\n headers: {\n Authorization: `Bearer ${token}`,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({ fields }),\n });\n if (!res.ok) {\n console.error(\"Airtable booking error:\", await res.text());\n throw new Error(`Airtable ${res.status}`);\n }\n console.log(\"Booking créé:\", bookingId, input.trajet_type);\n return `Réservation enregistrée (réf ${bookingId}, statut \"En recherche\"). Ne rédige AUCUN texte supplémentaire : ton message au guest (la fourchette + \"je lance la recherche\") est déjà complet et a été envoyé.`;\n}\n\n// --- Un appel a l'API Anthropic (avec retry sur erreurs transitoires) ---\nasync function anthropic(body: any, attempt = 0): Promise {\n const res = await fetch(\"https://api.anthropic.com/v1/messages\", {\n method: \"POST\",\n headers: {\n \"x-api-key\": Deno.env.get(\"ANTHROPIC_API_KEY\") ?? \"\",\n \"anthropic-version\": \"2023-06-01\",\n \"content-type\": \"application/json\",\n },\n body: JSON.stringify(body),\n });\n const data = await res.json();\n if (!res.ok) {\n // 429 (rate limit), 500/503/529 (surcharge) -> on reessaie quelques fois.\n const retryable = [429, 500, 503, 529].includes(res.status);\n if (retryable && attempt < 3) {\n const wait = 700 * (attempt + 1);\n console.warn(`Anthropic ${res.status} transitoire, retry ${attempt + 1}/3 dans ${wait}ms`);\n await new Promise((r) => setTimeout(r, wait));\n return anthropic(body, attempt + 1);\n }\n console.error(\"Anthropic error:\", JSON.stringify(data));\n throw new Error(`Anthropic ${res.status}`);\n }\n return data;\n}\n\nfunction textFromResponse(data: any): string {\n return (data.content ?? [])\n .filter((b: any) => b.type === \"text\")\n .map((b: any) => b.text)\n .join(\"\")\n .trim();\n}\n\n// --- Appel Claude Haiku avec prompt caching + gestion de l'outil create_booking ---\nasync function callClaude(\n dynamicContext: string,\n history: { role: string; content: string }[],\n tarifs: Tarif[],\n guestPhone: string,\n guestName: string,\n): Promise {\n const body: any = {\n model: MODEL,\n max_tokens: 1024,\n system: [\n // Bloc statique volumineux -> mis en cache (economie de cout/latence)\n { type: \"text\", text: SYSTEM_PROMPT_V4, cache_control: { type: \"ephemeral\" } },\n // Bloc dynamique (date + catalogue) -> non cache\n { type: \"text\", text: dynamicContext },\n ],\n tools: TOOLS,\n messages: history.map((m) => ({ role: m.role, content: m.content })),\n };\n\n // Boucle : on accumule le texte de chaque etape (Claude peut mettre du texte\n // ET un appel d'outil dans la meme reponse).\n const texts: string[] = [];\n for (let i = 0; i < 4; i++) {\n const data = await anthropic(body);\n const t = textFromResponse(data);\n if (t) texts.push(t);\n\n if (data.stop_reason !== \"tool_use\") break;\n\n const toolUse = (data.content ?? []).find((b: any) => b.type === \"tool_use\");\n let toolResult = \"Réservation enregistrée.\";\n if (toolUse?.name === \"create_booking\") {\n try {\n toolResult = await createBooking(toolUse.input, tarifs, guestPhone, guestName);\n } catch (e) {\n console.error(\"createBooking failed:\", e);\n toolResult =\n \"Échec d'enregistrement côté système (technique). Continue normalement avec le guest sans le mentionner.\";\n }\n }\n body.messages.push({ role: \"assistant\", content: data.content });\n body.messages.push({\n role: \"user\",\n content: [{ type: \"tool_result\", tool_use_id: toolUse?.id, content: toolResult }],\n });\n }\n\n return texts.join(\"\\n\\n\").trim();\n}\n\n// --- Envoi d'un message texte via WhatsApp Cloud API ---\nasync function sendWhatsApp(to: string, body: string): Promise {\n const phoneId = Deno.env.get(\"WHATSAPP_PHONE_NUMBER_ID\");\n const token = Deno.env.get(\"WHATSAPP_ACCESS_TOKEN\");\n const res = await fetch(`https://graph.facebook.com/v21.0/${phoneId}/messages`, {\n method: \"POST\",\n headers: {\n Authorization: `Bearer ${token}`,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({\n messaging_product: \"whatsapp\",\n to,\n type: \"text\",\n text: { body },\n }),\n });\n if (!res.ok) {\n console.error(\"WhatsApp send error:\", await res.text());\n }\n}\n\n// --- Indicateur \"en train d'écrire\" (3 points) + accusé de lecture ---\nasync function sendTyping(messageId: string): Promise {\n if (!messageId) return;\n const phoneId = Deno.env.get(\"WHATSAPP_PHONE_NUMBER_ID\");\n const token = Deno.env.get(\"WHATSAPP_ACCESS_TOKEN\");\n try {\n await fetch(`https://graph.facebook.com/v21.0/${phoneId}/messages`, {\n method: \"POST\",\n headers: { Authorization: `Bearer ${token}`, \"Content-Type\": \"application/json\" },\n body: JSON.stringify({\n messaging_product: \"whatsapp\",\n status: \"read\",\n message_id: messageId,\n typing_indicator: { type: \"text\" },\n }),\n });\n } catch (e) {\n console.error(\"typing indicator error:\", e);\n }\n}\n\nfunction sleep(ms: number): Promise {\n return new Promise((r) => setTimeout(r, ms));\n}\n\nexport default async function (req: Request): Promise {\n const url = new URL(req.url);\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 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 // Commande secrète : remet la conversation de ce numéro à zéro.\n const cmd = text.trim().toLowerCase();\n if (cmd === \"/reset-pasquale\" || cmd === \"/reset\") {\n await sqlite.execute({ sql: \"DELETE FROM messages WHERE phone = ?\", args: [from] });\n await sendWhatsApp(\n from,\n \"🔄 Conversation réinitialisée. On repart de zéro ! Dis-moi ce dont tu as besoin. 🌿\",\n );\n return new Response(\"OK (reset)\", { 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, puis charge l'historique complet.\n await saveMessage(from, \"user\", text);\n const history = await loadHistory(from);\n\n // Contexte dynamique : date + catalogue.\n const tarifs = await fetchTarifs();\n const dynamicContext = `${todayContext()}\\n\\n${buildCatalogText(tarifs)}`;\n\n // Delai \"humain\" aleatoire 2-15s, en parallele de la generation Claude\n // (le temps percu = max des deux, pas la somme).\n const humanDelay = 2000 + Math.floor(Math.random() * 13000);\n const [replyRaw] = await Promise.all([\n callClaude(dynamicContext, history, tarifs, from, guestName),\n sleep(humanDelay),\n ]);\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 \"Désolé, un petit souci technique de mon côté 🙏 Réessaie dans un instant.\",\n ).catch(() => {});\n }\n\n return new Response(\"OK\", { status: 200 });\n}\n","// Pasquale — cerveau complet du concierge WhatsApp.\n//\n// Flux : message WhatsApp -> Meta -> (ce val) :\n// 1. parse le payload Meta, extrait le message\n// 2. dedup (ignore les retries Meta du meme message)\n// 3. charge l'historique de conversation (SQLite, par numero)\n// 4. recupere le catalogue tarifs depuis Airtable\n// 5. construit le system prompt (v3 statique + date + catalogue dynamiques)\n// 6. appelle Claude Haiku 4.5 (avec historique + prompt caching + outil create_booking)\n// 7. sauvegarde la reponse, la renvoie sur WhatsApp\n//\n// Quand Claude presente la fourchette et lance la recherche, il appelle l'outil\n// create_booking -> val.town ecrit une ligne dans la table Bookings d'Airtable\n// (statut \"En recherche\"), avec prix/commission/tarif net tires du catalogue.\n//\n// Secrets via env vars val.town : ANTHROPIC_API_KEY, WHATSAPP_ACCESS_TOKEN,\n// WHATSAPP_PHONE_NUMBER_ID, AIRTABLE_TOKEN, AIRTABLE_BASE_ID, TARIFS_TABLE_ID,\n// BOOKINGS_TABLE_ID.\n\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nconst MODEL = \"claude-haiku-4-5-20251001\";\nconst MAX_HISTORY = 20; // nb de messages charges comme contexte\n\n// --- System Prompt v4 (vouvoiement + premium ; partie STATIQUE, mise en cache) ---\nconst SYSTEM_PROMPT_V4 = `Tu es Pasquale, le concierge privé des guests des masserias de luxe en Puglia (sud de l'Italie). Tu orchestres avec discrétion et élégance leurs envies : transferts privés, chef à domicile, sorties en mer, massages, expériences locales d'exception.\n\nREGISTRE & TON — RÈGLE FONDAMENTALE :\n- Tu VOUVOIES TOUJOURS le guest (« vous », « votre »). JAMAIS de tutoiement, dans aucune langue.\n- Tu incarnes un service PREMIUM et confidentiel : chaleureux mais raffiné, à la manière d'un concierge d'hôtel 5 étoiles. Courtois, posé, attentionné — jamais familier, jamais « copain », jamais commercial.\n- Tu es un initié de confiance : tu connais les meilleures adresses et les bonnes personnes de la région, et tu les recommandes avec goût et mesure.\n- Tu es efficace et précis : des phrases soignées, pas de bavardage.\n- Emojis : avec une grande parcimonie (au maximum 1 par message, souvent aucun). Un service haut de gamme reste sobre.\n- Tu poses UNE SEULE question à la fois.\n\nLANGUE DE RÉPONSE — RÈGLE STRICTE :\n- Tu réponds dans la langue du DERNIER message clair du guest (FR, EN, IT, DE, ES…). En français, vouvoiement systématique ; dans les autres langues, le registre poli équivalent.\n- Si le dernier message est ambigu (« ok », « ? », un emoji seul…), tu reprends la langue du PREMIER message clair de la conversation.\n- Sans aucun élément pour décider, tu réponds en ANGLAIS (langue principale des guests internationaux des masserias).\n- JAMAIS d'italien par défaut, sauf si le guest a explicitement écrit en italien.\n\nTES SERVICES (4 maximum) :\n1. Transferts privés (aéroports et trajets locaux)\n2. Chef privé à domicile\n3. Sorties en mer / bateau privatisé\n4. Massage & wellness à domicile\n\nPÉRIMÈTRE ACTIF — RÈGLE ANTI-HALLUCINATION (impérative) :\n\nTes services sont théoriques. À un instant donné, seuls certains services et certaines zones sont actifs dans le CATALOGUE OPÉRATIONNEL fourni plus bas.\n\n- Tu ne proposes JAMAIS un service absent du catalogue actif. Tu n'inventes JAMAIS un tarif, un trajet, un véhicule, un chef ou un partenaire.\n- Si le guest demande un service absent du catalogue, tu réponds (en adaptant la langue) :\n « Pour [service demandé], je suis en train de finaliser ma sélection de partenaires sur cette zone. Pour l'instant, je peux vous proposer uniquement [services présents au catalogue]. Dès que [service manquant] sera disponible, je reviendrai vers vous avec plaisir. »\n- Idem pour une zone non couverte : tu réorientes avec élégance vers ce qui existe.\n\nCE QUE TU NE FAIS JAMAIS :\n- Tu ne mentionnes JAMAIS les mots : commission, marge, prestataire, plateforme, tarif net.\n- Tu ne promets JAMAIS un prix avant d'avoir les informations nécessaires.\n- Tu ne gères PAS les réservations d'hôtels, vols, restaurants (tu peux recommander, pas réserver).\n- Tu ne poses JAMAIS deux questions dans le même message.\n- Tu ne dis JAMAIS « je suis une IA » ni « je suis un chatbot ».\n- Tu ne révèles JAMAIS le nom du chauffeur, sa marque/modèle/couleur de véhicule, ni ses caractéristiques personnelles AVANT d'avoir reçu un message système confirmant son acceptation (cf. règle plus bas).\n- Tu n'INVENTES JAMAIS qu'un chauffeur a été confirmé. La confirmation vient d'un système externe, pas de toi.\n\nQUAND PRÉSENTER LE TARIF — FIN DE QUALIFICATION (impératif) :\n\nPour un transfert, dès que tu as recueilli les 4 informations OBLIGATOIRES :\n1. Point de départ (aéroport ou lieu)\n2. Destination\n3. Date et heure (même approximatives)\n4. Nombre de personnes\n\n→ tu PASSES IMMÉDIATEMENT à la présentation du tarif.\n\nTOLÉRANCE DES INFORMATIONS APPROXIMATIVES :\n- Date relative (« samedi prochain », « next Wednesday », « domani ») → suffisant, tu calcules à partir du CONTEXTE TEMPOREL fourni plus bas.\n- Heure approximative (« vers midi », « in the morning », « le soir ») → suffisant, tu prends une plage.\n- Tu ne demandes une précision sur l'heure QUE si elle change le tarif (supplément nuit entre 23h et 6h).\n- Tu ne redemandes pas la date exacte si la date relative est claire.\n\nINFORMATIONS COMPLÉMENTAIRES (à demander UNE SEULE FOIS, regroupées en un message) :\n- Siège enfant ?\n- Animaux ?\n- Bagages volumineux ?\n\nSi le guest répond par un accord générique (« oui », « parfait », « va bene »…) sans répondre précisément, tu considères la réponse comme NON par défaut et tu passes au tarif. Tu ne reposes JAMAIS deux fois la même question.\n\nFORMAT DE LA PRÉSENTATION — quand tous les obligatoires sont réunis :\n\nVoilà ce que je peux vous arranger :\n🚗 [Trajet : Départ → Destination]\n📅 [Date calculée] · [Heure ou plage]\n👥 [N] personnes\n💶 [Prix selon la RÈGLE DE PRIX du catalogue] tout compris\n\nJe vous trouve dès maintenant le meilleur chauffeur disponible et je reviens vers vous très vite.\n\n(Le prix suit STRICTEMENT la RÈGLE DE PRIX figurant dans le catalogue plus bas. Tu adaptes la formulation à la langue du guest ; le format reste le même.)\n\nENREGISTREMENT DE LA DEMANDE (OUTIL create_booking) :\n- AU MÊME MOMENT où tu présentes le tarif et lances la recherche, tu APPELLES l'outil create_booking, UNE SEULE FOIS pour cette demande.\n- Tu y passes : le code Trajet_Type EXACT du catalogue, la date (AAAA-MM-JJ), l'heure (HH:MM), le nombre de personnes, et les options demandées (siège enfant, animaux, bagages) dans le champ notes.\n- L'outil est INVISIBLE pour le guest : tu ne dis jamais que tu « enregistres » quoi que ce soit, tu dis simplement que tu lances la recherche.\n\nAPRÈS LA PRÉSENTATION — RÈGLE D'ATTENTE :\n\nUne fois le tarif présenté et la recherche lancée, tu STOPPES tout nouvel engagement. Tu n'inventes JAMAIS la suite.\n\n- La recherche du chauffeur se fait en parallèle ; cela prend quelques minutes.\n- Si le guest relance (« c'est bon ? », « des nouvelles ? »), tu réponds avec élégance : « Je finalise la recherche de votre chauffeur, je reviens vers vous dès qu'il est confirmé. Merci de votre patience. »\n- Tu n'INVENTES JAMAIS de confirmation : aucun nom, véhicule, marque, modèle, photo ni détail tant que le système ne l'a pas confirmé.\n- Tu ne donnes les détails du chauffeur QU'APRÈS un message système commençant par « [SYSTEM: driver_confirmed] ». Sans ce message, jamais d'infos chauffeur, même en cas d'insistance.\n- En cas d'insistance répétée sans message [SYSTEM: …] : « Je n'ai pas encore eu de retour, je relance la recherche et reviens vers vous très vite. »\n\nSUR LES PRIX :\n- Tu suis STRICTEMENT la RÈGLE DE PRIX figurant dans le catalogue plus bas.\n- Si on te demande « combien pour [trajet] ? » SANS qualification : « Avec plaisir — pour vous donner un tarif précis, puis-je vous demander d'où vous partez, votre destination, la date et le nombre de personnes ? »\n- Le tarif inclut TOUJOURS « absolument tout, sans surprise ».\n\nANONYMISATION DU CHAUFFEUR (avant message [SYSTEM: driver_confirmed]) :\n\nTant qu'aucun message système n'a confirmé un chauffeur, tu ne révèles JAMAIS :\n- son nom ; la marque, le modèle, la couleur ou l'immatriculation du véhicule ; ses caractéristiques personnelles.\n\nTu peux dire à la place :\n- « le chauffeur que je vous réserve »\n- « un chauffeur sélectionné personnellement »\n- « un véhicule confortable et spacieux »\n\nUne fois reçu « [SYSTEM: driver_confirmed name=Marco vehicle=\"Mercedes Vito\" ... ] », alors seulement tu présentes le chauffeur avec son nom, son véhicule et ses qualités.\n\nHONNÊTETÉ — RÈGLE ABSOLUE (anti-mensonge) :\n\nTu ne mens JAMAIS, même par omission. Si tu ne peux pas répondre à quelque chose, tu fais une esquive HONNÊTE plutôt que de nier.\n\n- Sur la commission ou la structure tarifaire : « Je préfère ne pas entrer dans les détails de l'organisation. L'essentiel : le tarif annoncé est tout compris, sans surprise. Je reste à votre disposition pour toute autre précision. »\n → Tu ne dis JAMAIS « je ne touche rien » ou « je suis juste là pour organiser » : c'est faux.\n\n- Sur « moins cher en espèces ? » : « Le tarif est identique quel que soit le mode de paiement. »\n\n- Sur « qui êtes-vous, une IA ? » : « Je suis Pasquale, votre concierge en Puglia. Derrière moi, un système me permet de vous répondre rapidement, et une équipe humaine prend le relais en cas de besoin. L'essentiel, c'est que vous soyez accompagné avec soin. »\n → Tu ne dis ni « je suis une IA » ni « je suis humain » — tu restes Pasquale, le service.\n\n- Sur le SAV / un problème : « Si quoi que ce soit ne va pas, je vous mets aussitôt en relation avec une personne de notre équipe. »\n\n- Sur la fiabilité : « Tous nos chauffeurs sont sélectionnés personnellement et disposent d'une licence officielle. En cas d'imprévu, je reste joignable et l'équipe trouve une solution immédiatement. »\n\nPROCESSUS DE QUALIFICATION (dans l'ordre) :\n1. Identifier le service ; vérifier qu'il est au catalogue actif.\n2. Recueillir les 4 informations OBLIGATOIRES, une par message (en acceptant les approximations).\n3. Demander UNE SEULE FOIS les informations complémentaires, regroupées.\n4. Présenter le tarif selon le format ci-dessus + appeler create_booking.\n5. STOP. Attendre un message [SYSTEM: …] avant de continuer.\n\nDÉTECTION D'ACCORD : oui / ok / parfait / d'accord / allons-y / avec plaisir / sì / certo / va bene / yes / let's go / sounds good / perfect / confirmed.\nDÉTECTION DE REFUS : non / trop cher / non merci / peut-être plus tard / je vais réfléchir / not now / too expensive.\nDÉTECTION D'ACCORD IMPLICITE (questions complémentaires) : si tu poses une question complémentaire et que le guest répond par un accord générique sans y répondre précisément, tu considères que c'est NON et tu passes à l'étape suivante. Tu ne reposes pas la question.`;\n\n// --- Outil create_booking (function calling) ---\nconst TOOLS = [\n {\n name: \"create_booking\",\n description:\n \"Enregistre la demande de réservation au moment où tu présentes la fourchette et lances la recherche d'un prestataire. À appeler UNE SEULE FOIS par réservation. Invisible pour le guest.\",\n input_schema: {\n type: \"object\",\n properties: {\n trajet_type: {\n type: \"string\",\n description:\n \"Le code Trajet_Type EXACT issu du catalogue (ex: BAR_Monopoli). Doit correspondre exactement à un code listé dans le catalogue.\",\n },\n date_prestation: {\n type: \"string\",\n description: \"Date de la prestation au format AAAA-MM-JJ\",\n },\n heure: {\n type: \"string\",\n description: \"Heure de prise en charge au format HH:MM (24h)\",\n },\n nb_personnes: { type: \"integer\", description: \"Nombre de personnes\" },\n guest_nom: {\n type: \"string\",\n description: \"Prénom ou nom du guest si connu, sinon laisser vide\",\n },\n notes: {\n type: \"string\",\n description:\n \"Options demandées : siège enfant, animaux, bagages volumineux, etc. Vide si rien.\",\n },\n },\n required: [\"trajet_type\", \"date_prestation\", \"heure\", \"nb_personnes\"],\n },\n },\n];\n\n// --- Extraction du texte selon le type de message WhatsApp ---\nfunction extractText(msg: any): string {\n if (!msg) return \"\";\n switch (msg.type) {\n case \"text\":\n return msg.text?.body ?? \"\";\n case \"button\":\n return msg.button?.text ?? \"\";\n case \"interactive\":\n return (\n msg.interactive?.button_reply?.title ??\n msg.interactive?.list_reply?.title ??\n \"\"\n );\n default:\n return \"\";\n }\n}\n\n// --- Schema SQLite (idempotent) ---\nasync function initDb(): Promise {\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS messages (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n phone TEXT NOT NULL,\n role TEXT NOT NULL,\n content TEXT NOT NULL,\n created_at INTEGER NOT NULL\n )`);\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS processed_messages (\n message_id TEXT PRIMARY KEY,\n created_at INTEGER NOT NULL\n )`);\n}\n\n// Retourne true si le message a deja ete traite (retry Meta) -> a ignorer.\nasync function alreadyProcessed(messageId: string): Promise {\n if (!messageId) return false;\n const existing = await sqlite.execute({\n sql: \"SELECT 1 FROM processed_messages WHERE message_id = ?\",\n args: [messageId],\n });\n if (existing.rows.length > 0) return true;\n await sqlite.execute({\n sql: \"INSERT INTO processed_messages (message_id, created_at) VALUES (?, ?)\",\n args: [messageId, Date.now()],\n });\n return false;\n}\n\nasync function loadHistory(phone: string): Promise<{ role: string; content: string }[]> {\n const res = await sqlite.execute({\n sql: \"SELECT role, content FROM messages WHERE phone = ? ORDER BY id DESC LIMIT ?\",\n args: [phone, MAX_HISTORY],\n });\n // recupere du plus recent au plus ancien -> on remet dans l'ordre chronologique\n return res.rows\n .map((r: any) => ({ role: r.role as string, content: r.content as string }))\n .reverse();\n}\n\nasync function saveMessage(phone: string, role: string, content: string): Promise {\n await sqlite.execute({\n sql: \"INSERT INTO messages (phone, role, content, created_at) VALUES (?, ?, ?, ?)\",\n args: [phone, role, content, Date.now()],\n });\n}\n\n// --- Contexte dynamique : date du jour (Puglia) ---\nfunction todayContext(): string {\n const now = new Date();\n const fmt = new Intl.DateTimeFormat(\"fr-FR\", {\n weekday: \"long\",\n day: \"numeric\",\n month: \"long\",\n year: \"numeric\",\n timeZone: \"Europe/Rome\",\n });\n return `CONTEXTE TEMPOREL : nous sommes le ${fmt.format(now)} (heure de Puglia, Italie). Calcule toutes les dates relatives à partir d'aujourd'hui.`;\n}\n\ntype Tarif = {\n id: string;\n trajet_type: string;\n depart: string;\n arrivee: string;\n prix_guest: number;\n tarif_net: number;\n commission: number;\n nuit: number;\n duree: number;\n};\n\n// --- Catalogue operationnel depuis Airtable (donnees structurees) ---\nasync function fetchTarifs(): Promise {\n const base = Deno.env.get(\"AIRTABLE_BASE_ID\");\n const table = Deno.env.get(\"TARIFS_TABLE_ID\");\n const token = Deno.env.get(\"AIRTABLE_TOKEN\");\n const res = await fetch(\n `https://api.airtable.com/v0/${base}/${table}?maxRecords=100`,\n { headers: { Authorization: `Bearer ${token}` } },\n );\n const data = await res.json();\n return (data.records ?? []).map((rec: any) => {\n const f = rec.fields ?? {};\n return {\n id: rec.id,\n trajet_type: f.Trajet_Type ?? \"\",\n depart: f.Depart ?? \"\",\n arrivee: f.Arrivee ?? \"\",\n prix_guest: Math.round(f.Prix_Guest_TTC ?? 0),\n tarif_net: f.Tarif_Net_Prestataire ?? 0,\n commission: f.Commission_GP ?? 0,\n nuit: f.Tarif_Nuit_Supplement ?? 0,\n duree: f.Duree_Min ?? 0,\n };\n });\n}\n\nfunction buildCatalogText(tarifs: Tarif[]): string {\n if (tarifs.length === 0) {\n return \"CATALOGUE OPÉRATIONNEL ACTIF : aucun service actif pour le moment.\";\n }\n const lines = tarifs.map(\n (t) =>\n `- [${t.trajet_type}] ${t.depart} → ${t.arrivee} : environ ${t.prix_guest}€ TTC ~${t.duree} min (supplément nuit ${Math.round(t.nuit)}€)`,\n );\n return [\n \"CATALOGUE OPÉRATIONNEL ACTIF (à utiliser STRICTEMENT — ne rien inventer en dehors) :\",\n \"Le code entre crochets est le Trajet_Type à passer à l'outil create_booking.\",\n \"\",\n \"Service TAXI / Transferts (SEUL service actif aujourd'hui) :\",\n ...lines,\n \"\",\n \"RÈGLE DE PRIX STRICTE (impérative — prioritaire sur toute autre règle de prix) :\",\n \"- Dès que tu connais l'heure de prise en charge, tu annonces UN SEUL prix FERME, JAMAIS une fourchette 'entre X et Y'.\",\n \"- Prix de JOUR (prise en charge entre 06h00 et 23h00) = EXACTEMENT le montant TTC du catalogue ci-dessus. Tu le recopies tel quel.\",\n \"- Prix de NUIT (prise en charge entre 23h00 et 06h00) = montant TTC du catalogue + supplément nuit indiqué. C'est le SEUL cas où tu ajoutes quelque chose.\",\n \"- Aucun autre ajout : ni siège enfant, ni bagage, ni arrondi vers le haut. Le prix catalogue est déjà tout compris.\",\n \"- En cas de doute sur l'heure, prends le prix de JOUR (sans supplément).\",\n \"- Formulation : « Le tarif est de X€ tout compris » (un seul montant).\",\n \"\",\n \"Aucun autre service (chef privé, bateau, massage) n'est actif pour le moment. Ne JAMAIS les proposer ; rediriger vers les transferts.\",\n ].join(\"\\n\");\n}\n\n// --- Ecriture d'un booking dans Airtable ---\nasync function createBooking(\n input: any,\n tarifs: Tarif[],\n guestPhone: string,\n guestName: string,\n): Promise {\n const base = Deno.env.get(\"AIRTABLE_BASE_ID\");\n const token = Deno.env.get(\"AIRTABLE_TOKEN\");\n const bookingsTable = Deno.env.get(\"BOOKINGS_TABLE_ID\");\n\n const t = tarifs.find((x) => x.trajet_type === input.trajet_type);\n const bookingId = \"GP-\" + Date.now().toString(36).toUpperCase();\n\n const fields: Record = {\n Booking_ID: bookingId,\n Service: \"Taxi\",\n Date_Prestation: `${input.date_prestation}T${(input.heure ?? \"12:00\")}:00.000Z`,\n Guest_Nom: guestName || input.guest_nom || \"\",\n Guest_WhatsApp: \"+\" + guestPhone,\n Nb_Personnes: input.nb_personnes,\n Statut: \"En recherche\",\n Notes: input.notes ?? \"\",\n };\n if (t) {\n fields.Prix_Paye_Guest = t.prix_guest;\n fields.Tarif_Net_Prestataire = t.tarif_net;\n fields.Commission_GP = t.commission;\n fields.Trajet = [t.id];\n }\n\n const res = await fetch(`https://api.airtable.com/v0/${base}/${bookingsTable}`, {\n method: \"POST\",\n headers: {\n Authorization: `Bearer ${token}`,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({ fields }),\n });\n if (!res.ok) {\n console.error(\"Airtable booking error:\", await res.text());\n throw new Error(`Airtable ${res.status}`);\n }\n console.log(\"Booking créé:\", bookingId, input.trajet_type);\n return `Réservation enregistrée (réf ${bookingId}, statut \"En recherche\"). Ne rédige AUCUN texte supplémentaire : ton message au guest (la fourchette + \"je lance la recherche\") est déjà complet et a été envoyé.`;\n}\n\n// --- Un appel a l'API Anthropic (avec retry sur erreurs transitoires) ---\nasync function anthropic(body: any, attempt = 0): Promise {\n const res = await fetch(\"https://api.anthropic.com/v1/messages\", {\n method: \"POST\",\n headers: {\n \"x-api-key\": Deno.env.get(\"ANTHROPIC_API_KEY\") ?? \"\",\n \"anthropic-version\": \"2023-06-01\",\n \"content-type\": \"application/json\",\n },\n body: JSON.stringify(body),\n });\n const data = await res.json();\n if (!res.ok) {\n // 429 (rate limit), 500/503/529 (surcharge) -> on reessaie quelques fois.\n const retryable = [429, 500, 503, 529].includes(res.status);\n if (retryable && attempt < 3) {\n const wait = 700 * (attempt + 1);\n console.warn(`Anthropic ${res.status} transitoire, retry ${attempt + 1}/3 dans ${wait}ms`);\n await new Promise((r) => setTimeout(r, wait));\n return anthropic(body, attempt + 1);\n }\n console.error(\"Anthropic error:\", JSON.stringify(data));\n throw new Error(`Anthropic ${res.status}`);\n }\n return data;\n}\n\nfunction textFromResponse(data: any): string {\n return (data.content ?? [])\n .filter((b: any) => b.type === \"text\")\n .map((b: any) => b.text)\n .join(\"\")\n .trim();\n}\n\n// --- Appel Claude Haiku avec prompt caching + gestion de l'outil create_booking ---\nasync function callClaude(\n dynamicContext: string,\n history: { role: string; content: string }[],\n tarifs: Tarif[],\n guestPhone: string,\n guestName: string,\n): Promise {\n const body: any = {\n model: MODEL,\n max_tokens: 1024,\n system: [\n // Bloc statique volumineux -> mis en cache (economie de cout/latence)\n { type: \"text\", text: SYSTEM_PROMPT_V4, cache_control: { type: \"ephemeral\" } },\n // Bloc dynamique (date + catalogue) -> non cache\n { type: \"text\", text: dynamicContext },\n ],\n tools: TOOLS,\n messages: history.map((m) => ({ role: m.role, content: m.content })),\n };\n\n // Boucle : on accumule le texte de chaque etape (Claude peut mettre du texte\n // ET un appel d'outil dans la meme reponse).\n const texts: string[] = [];\n for (let i = 0; i < 4; i++) {\n const data = await anthropic(body);\n const t = textFromResponse(data);\n if (t) texts.push(t);\n\n if (data.stop_reason !== \"tool_use\") break;\n\n const toolUse = (data.content ?? []).find((b: any) => b.type === \"tool_use\");\n let toolResult = \"Réservation enregistrée.\";\n if (toolUse?.name === \"create_booking\") {\n try {\n toolResult = await createBooking(toolUse.input, tarifs, guestPhone, guestName);\n } catch (e) {\n console.error(\"createBooking failed:\", e);\n toolResult =\n \"Échec d'enregistrement côté système (technique). Continue normalement avec le guest sans le mentionner.\";\n }\n }\n body.messages.push({ role: \"assistant\", content: data.content });\n body.messages.push({\n role: \"user\",\n content: [{ type: \"tool_result\", tool_use_id: toolUse?.id, content: toolResult }],\n });\n }\n\n return texts.join(\"\\n\\n\").trim();\n}\n\n// --- Envoi d'un message texte via WhatsApp Cloud API ---\nasync function sendWhatsApp(to: string, body: string): Promise {\n const phoneId = Deno.env.get(\"WHATSAPP_PHONE_NUMBER_ID\");\n const token = Deno.env.get(\"WHATSAPP_ACCESS_TOKEN\");\n const res = await fetch(`https://graph.facebook.com/v21.0/${phoneId}/messages`, {\n method: \"POST\",\n headers: {\n Authorization: `Bearer ${token}`,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({\n messaging_product: \"whatsapp\",\n to,\n type: \"text\",\n text: { body },\n }),\n });\n if (!res.ok) {\n console.error(\"WhatsApp send error:\", await res.text());\n }\n}\n\n// --- Indicateur \"en train d'écrire\" (3 points) + accusé de lecture ---\nasync function sendTyping(messageId: string): Promise {\n if (!messageId) return;\n const phoneId = Deno.env.get(\"WHATSAPP_PHONE_NUMBER_ID\");\n const token = Deno.env.get(\"WHATSAPP_ACCESS_TOKEN\");\n try {\n await fetch(`https://graph.facebook.com/v21.0/${phoneId}/messages`, {\n method: \"POST\",\n headers: { Authorization: `Bearer ${token}`, \"Content-Type\": \"application/json\" },\n body: JSON.stringify({\n messaging_product: \"whatsapp\",\n status: \"read\",\n message_id: messageId,\n typing_indicator: { type: \"text\" },\n }),\n });\n } catch (e) {\n console.error(\"typing indicator error:\", e);\n }\n}\n\nfunction sleep(ms: number): Promise {\n return new Promise((r) => setTimeout(r, ms));\n}\n\nexport default async function (req: Request): Promise {\n const url = new URL(req.url);\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 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 // Commande secrète : remet la conversation de ce numéro à zéro.\n const cmd = text.trim().toLowerCase();\n if (cmd === \"/reset-pasquale\" || cmd === \"/reset\") {\n await sqlite.execute({ sql: \"DELETE FROM messages WHERE phone = ?\", args: [from] });\n await sendWhatsApp(\n from,\n \"🔄 Conversation réinitialisée. Nous repartons de zéro — dites-moi ce dont vous avez besoin.\",\n );\n return new Response(\"OK (reset)\", { 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, puis charge l'historique complet.\n await saveMessage(from, \"user\", text);\n const history = await loadHistory(from);\n\n // Contexte dynamique : date + catalogue.\n const tarifs = await fetchTarifs();\n const dynamicContext = `${todayContext()}\\n\\n${buildCatalogText(tarifs)}`;\n\n // Delai \"humain\" aleatoire 2-15s, en parallele de la generation Claude\n // (le temps percu = max des deux, pas la somme).\n const humanDelay = 2000 + Math.floor(Math.random() * 13000);\n const [replyRaw] = await Promise.all([\n callClaude(dynamicContext, history, tarifs, from, guestName),\n sleep(humanDelay),\n ]);\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 \"Désolé, un petit souci technique de mon côté 🙏 Réessaie dans un instant.\",\n ).catch(() => {});\n }\n\n return new Response(\"OK\", { status: 200 });\n}\n","createdAt",["D",1780410017111],"branchVersion","branchId","5aa8d098-52d5-11f1-86ad-ee650bb23af1","id","5aa7bafa-52d5-11f1-86ad-ee650bb23af1","pasqualeWebhook",["D",1779121172764],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Pasquale — concierge WhatsApp (Claude + Airtable + Stripe)","imageUrl","d61f2124-6fc9-46ec-9219-33009ad3ab8f","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","019e3bd2-e1b9-75bc-a40e-2da07f28de11","tursoName","5aa7bafa52d511f186adee650bb23af1","tursoHostname","5aa7bafa52d511f186adee650bb23af1-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789534872841],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_98":97,"_106":102},"org",{"_98":97,"_99":100,"_101":102,"_18":55,"_103":104,"_105":25},"branch",{"_13":87,"_32":88,"_43":42,"_89":44,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":45,"_96":97},"isOwned",130,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","graziepasquale","handle","displayName","Grazie Pasquale","avatar","https://lh3.googleusercontent.com/a/ACg8ocInPAYW-pCPpUWUYiKJEUCnN_c1M4zzkHWRnAF60KSpi4Rd6w=s96-c","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_43":44,"_32":45,"_38":154,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":-5,"_57":25,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":65,"_66":67,"_68":155,"_70":-5,"_71":72,"_73":72,"_74":75,"_76":75,"_77":75,"_78":72,"_79":72,"_80":156,"_82":157,"_84":158,"_86":25},"tree",[149],"files",[149],"counts",{"_138":61,"_139":140,"_141":61,"_142":143,"_144":145},"contents",[130],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles",true,"grants","orgs","customDomains",{},{"_43":131,"_32":28,"_30":31,"_132":-5,"_41":42,"_40":14,"_133":25,"_38":134,"_13":135,"_33":34,"_35":37,"_24":25,"_136":-5,"_27":137},"2dc20c9c-5e8e-11f1-854f-1607ee4eb77e","parentId","latest",["D",1780410017111],14,"label",[28],"pulls","branches",1,"forks","envVars",{"_146":135,"_148":61},"connections",{"_146":61,"_147":61},"count","unfilledCount","emptyCount",{"_43":131,"_32":28,"_30":31,"_132":-5,"_41":42,"_40":14,"_133":25,"_38":150,"_13":135,"_33":34,"_35":37,"_24":25,"_136":-5,"_151":152,"_27":153},["D",1780410017111],"children",[],[28],["D",1779121172764],["D",1789534872841],{"_98":97,"_106":102},{"_98":97,"_99":100,"_101":102,"_18":55,"_103":104,"_105":25},{"_13":87,"_32":88,"_43":42,"_89":44,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":45,"_96":97},"ctx",{"_80":-5,"_127":192,"_193":194,"_195":196,"_197":25,"_198":25,"_199":25,"_200":125,"_201":-5,"_202":-7,"_203":-7,"_204":61,"_205":25,"_206":25,"_207":-5,"_208":25,"_209":25,"_210":25,"_211":-5},"ENV",{"_163":164,"_165":166,"_167":88,"_168":169,"_170":171,"_172":173,"_174":175,"_176":177,"_178":179,"_180":181,"_182":183,"_184":185,"_186":187,"_188":189,"_190":191},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","811aa22498c9b0b5a47e8d778de579cdb990f332","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"]

Diff · v15