[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_154":155,"_156":157},"routes/_app.x.$handle.$name",{"_95":94,"_32":45,"_104":85,"_27":53,"_13":14,"_105":-5,"_11":106,"_107":108,"_109":110,"_111":112,"_113":114,"_20":-5,"_115":-5,"_116":-5,"_117":25,"_118":119,"_120":58,"_121":-5,"_122":-5,"_123":124},"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":31,"_57":58,"_59":-5,"_60":-5,"_61":62,"_63":64,"_65":-5,"_66":-5,"_67":-5,"_68":-5,"_69":70,"_71":70,"_72":73,"_74":73,"_75":73,"_76":70,"_77":70,"_78":79,"_80":81,"_82":83,"_84":25},"version",18,"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","77ed9748-9e0b-11f1-8eee-1607ee4eb77e","name","fileType","http","content","// Comptes linge — un seul fichier, pour Val Town (https://val.town)\n// À coller dans un nouveau \"HTTP val\". Règle ensuite les variables dans\n// l'onglet \"Environment Variables\" (barre de gauche).\n//\n// Variables :\n// LODGIFY_API_KEY (obligatoire) Lodgify -> Réglages -> Public API\n// GROQ_API_KEY (obligatoire) console.groq.com\n// LINGE_PASSWORD (conseillé) mot de passe pour ouvrir la page\n// PRIX_COMPLET / PRIX_SERVIETTES / PRIX_LINGE_LIT (facultatif : repli si aucun montant dans le chat)\n// CLASSIFIER_MODEL (facultatif, défaut llama-3.3-70b-versatile)\n\nimport { sqlite } from \"https://esm.town/v/std/sqlite\";\n\nconst LODGIFY = Deno.env.get(\"LODGIFY_API_KEY\");\nconst GROQ = Deno.env.get(\"GROQ_API_KEY\");\nconst GEMINI = Deno.env.get(\"GEMINI_API_KEY\");\nconst PASSWORD = Deno.env.get(\"LINGE_PASSWORD\") || \"\";\n// Détection automatique : si tu mets une clé Gemini, il l'utilise ; sinon Groq.\nconst PROVIDER = (Deno.env.get(\"LLM_PROVIDER\") || (GEMINI ? \"gemini\" : \"groq\")).toLowerCase();\nconst MODEL = Deno.env.get(\"CLASSIFIER_MODEL\") || (PROVIDER === \"gemini\" ? \"gemini-2.5-flash\" : \"llama-3.3-70b-versatile\");\nconst BUDGET_MS = 5000; // très court : chaque requête finit vite, jamais de 502 (lecture par mini-tranches)\n\nconst num = (v: string | undefined, d: number) => {\n const n = parseFloat(String(v ?? \"\").replace(\",\", \".\"));\n return isNaN(n) ? d : n;\n};\nconst PRIX: Record = {\n complet: num(Deno.env.get(\"PRIX_COMPLET\"), 0),\n serviettes: num(Deno.env.get(\"PRIX_SERVIETTES\"), 0),\n linge_lit: num(Deno.env.get(\"PRIX_LINGE_LIT\"), 0),\n aucun: 0,\n indetermine: 0,\n};\nconst LABELS: Record = {\n complet: \"Linge complet\",\n serviettes: \"Serviettes\",\n linge_lit: \"Linge de lit\",\n aucun: \"Aucun\",\n indetermine: \"À vérifier\",\n};\n// On ne rejette QUE les réservations clairement annulées/refusées (français et anglais).\n// Tout le reste (\"Réservé\", \"Booked\"…) est compté : mieux vaut inclure que perdre un séjour.\nconst EXCLUDED = [\n \"declined\", \"refusé\", \"refuse\",\n \"cancelled\", \"canceled\", \"annulé\", \"annule\",\n \"trash\", \"corbeille\",\n \"deleted\", \"supprimé\", \"supprime\",\n];\n\n/* ---------- cache SQLite ---------- */\nlet tableReady = false;\nasync function ensureTable() {\n if (tableReady) return;\n await sqlite.execute(\"CREATE TABLE IF NOT EXISTS linge_cache (k TEXT PRIMARY KEY, v TEXT)\");\n tableReady = true;\n}\nasync function cacheGet(k: string) {\n await ensureTable();\n const r = await sqlite.execute({ sql: \"SELECT v FROM linge_cache WHERE k = ?\", args: [k] });\n const row = r.rows?.[0];\n if (!row) return null;\n try { return JSON.parse(row[0] as string); } catch { return null; }\n}\nasync function cacheSet(k: string, v: unknown) {\n await ensureTable();\n await sqlite.execute({ sql: \"INSERT OR REPLACE INTO linge_cache (k, v) VALUES (?, ?)\", args: [k, JSON.stringify(v)] });\n}\n\n/* ---------- Lodgify ---------- */\nconst API = \"https://api.lodgify.com/v2\";\nasync function lg(path: string, params: Record = {}) {\n const url = new URL(API + path);\n for (const [k, v] of Object.entries(params)) if (v != null) url.searchParams.set(k, String(v));\n const res = await fetch(url.toString(), { headers: { \"X-ApiKey\": LODGIFY as string, accept: \"application/json\" } });\n if (!res.ok) throw new Error(\"Lodgify \" + res.status + \" sur \" + path + \" : \" + (await res.text().catch(() => \"\")).slice(0, 160));\n return res.json();\n}\nasync function fetchOneFilter(stayFilter: string, byId: Map) {\n const size = 50; // Lodgify plafonne les pages à 50 : demander plus casse la pagination\n for (let page = 1; page <= 100; page++) {\n let data: any;\n try {\n data = await lg(\"/reservations/bookings\", { page, size, stayFilter, includeExternal: true, trash: false, includeCount: false });\n } catch {\n break;\n }\n const items = data?.items ?? data?.bookings ?? (Array.isArray(data) ? data : []);\n if (!items.length) break; // page vide = terminé\n for (const b of items) {\n const id = String(b?.id ?? b?.booking_id ?? (b?.arrival + \"_\" + b?.property_id));\n byId.set(id, b);\n }\n if (items.length < size) break; // page incomplète = dernière page\n }\n}\n\nasync function fetchAllBookings() {\n // passé + présent + futur, en SÉQUENTIEL (le parallèle faisait perdre des résultats)\n const byId = new Map();\n for (const f of [\"Upcoming\", \"Current\", \"Historic\", \"All\"]) {\n await fetchOneFilter(f, byId);\n }\n return Array.from(byId.values());\n}\nasync function fetchPropertyNames() {\n const map: Record = {};\n try {\n const data = await lg(\"/properties\", { page: 1, size: 50 });\n const items = data?.items ?? data?.properties ?? (Array.isArray(data) ? data : []);\n for (const p of items) {\n const id = String(p.id ?? p.property_id ?? p.house_id ?? \"\");\n if (id) map[id] = p.name ?? p.title ?? (\"Logement \" + id);\n }\n } catch { /* on retombera sur l'ID */ }\n return map;\n}\n\nconst pick = (o: any, ks: string[]) => { for (const k of ks) if (o?.[k] != null && o[k] !== \"\") return o[k]; return undefined; };\nconst propId = (b: any) => String(pick(b, [\"property_id\", \"house_id\", \"rental_id\", \"propertyId\"]) ?? b?.rooms?.[0]?.property_id ?? \"\");\nconst departure = (b: any) => pick(b, [\"departure\", \"date_departure\", \"departureDate\", \"checkOut\", \"check_out\", \"end\"]);\nconst guestName = (b: any) => b?.guest?.name ?? pick(b, [\"guest_name\", \"guestName\"]) ?? \"\";\nconst statusOf = (b: any) => String(pick(b, [\"status\", \"state\"]) ?? \"\").toLowerCase();\nconst threadGuid = (b: any) => pick(b, [\"thread_uid\", \"thread_guid\", \"threadGuid\", \"messaging_thread_guid\", \"conversation_guid\", \"guid\"]);\n\nfunction extractTranscript(thread: any) {\n const msgs = thread?.messages ?? thread?.Messages ?? thread?.thread?.messages ?? [];\n if (Array.isArray(msgs) && msgs.length) {\n const lines = msgs.map((m: any) => {\n const text = pick(m, [\"message\", \"content\", \"text\", \"body\", \"Message\"]);\n if (!text) return \"\";\n const src = String(pick(m, [\"source\", \"from\", \"author\", \"sender\", \"direction\"]) ?? \"\").toLowerCase();\n const host = m.is_host ?? m.isHost ?? src.includes(\"host\") ?? src.includes(\"out\");\n return (host ? \"Hôte\" : \"Voyageur\") + \": \" + String(text).replace(/\\s+/g, \" \").trim();\n }).filter(Boolean);\n if (lines.length) return lines.join(\"\\n\").slice(0, 7000);\n }\n return JSON.stringify(thread).slice(0, 7000);\n}\n\n/* ---------- lecture par l'IA ---------- */\nconst SYSTEM = [\n \"Tu lis une conversation en français entre l'hôte d'une location saisonnière et un voyageur.\",\n \"Lis et COMPRENDS toute la conversation. Ton but : déterminer ce que le voyageur a réellement pris comme linge de maison payant (en supplément, réglé en espèces au départ) ET la somme à compter.\",\n \"\",\n \"COMMENT SAVOIR SI L'OPTION EST PRISE (règle essentielle) :\",\n \"- L'hôte ne confirme un montant à régler QUE lorsque le voyageur a accepté l'option. Sa phrase de confirmation ressemble à : « il faudra laisser X euros sur la table lors de votre départ » — mais comprends l'INTENTION, pas les mots exacts (les formulations varient).\",\n \"- Si cette confirmation de montant par l'hôte est présente → l'option est PRISE, et le montant à compter est CE montant-là.\",\n \"- Si elle est ABSENTE → l'option n'a pas été prise → categorie \\\"aucun\\\", montant 0. C'est le cas si le voyageur refuse, dit qu'il apporte son propre linge/ses draps/ses serviettes, ne répond pas, ou si le sujet n'est jamais confirmé.\",\n \"\",\n \"INTERDICTION IMPORTANTE :\",\n \"- N'invente JAMAIS un montant à partir d'un chiffre qui traîne (un prix général évoqué, un numéro, une date, un tarif de ménage, un autre sujet). Un montant ne compte QUE s'il est clairement rattaché à la confirmation du linge par l'hôte.\",\n \"- Le dernier choix exprimé par le voyageur l'emporte toujours (s'il accepte puis se rétracte → aucun).\",\n \"\",\n \"Catégories :\",\n '- \"complet\" : linge complet (draps ET serviettes).',\n '- \"serviettes\" : uniquement les serviettes.',\n '- \"linge_lit\" : uniquement les draps / linge de lit.',\n '- \"aucun\" : rien de payant pris (refus, apporte le sien, ou pas de confirmation de montant).',\n '- \"indetermine\" : la conversation parle du linge mais il est vraiment impossible de trancher.',\n \"\",\n \"Montant :\",\n '- \"montant_convenu\" = la somme EN EUROS que l\\'hôte confirme à laisser au départ. 0 si aucun.',\n \"- CE MONTANT SE TROUVE DANS LA PHRASE DE CONFIRMATION DE L'HÔTE, du type « il faudra laisser X euros sur la table lors de votre départ ». Prends CE chiffre-là en priorité absolue.\",\n \"- Lis le nombre EXACT, même collé ou sans espace : « 45euros », « 45 euros », « 45€ » valent tous 45. Ne le confonds jamais avec un autre chiffre de la conversation (heure, code d'accès, prix du séjour…).\",\n \"- S'il y a plusieurs montants, celui de la phrase de confirmation finale de l'hôte l'emporte. Si aucune phrase de confirmation de montant n'existe → \\\"aucun\\\", montant 0.\",\n \"\",\n \"Confiance : \\\"haute\\\" si c'est net (refus clair, ou confirmation de montant claire) ; \\\"moyenne\\\"/\\\"basse\\\" si ça demande interprétation.\",\n \"\",\n 'Réponds UNIQUEMENT en JSON : {\"categorie\":\"complet|serviettes|linge_lit|aucun|indetermine\",\"montant_convenu\":nombre ou null,\"confiance\":\"haute|moyenne|basse\",\"justification\":\"courte raison, en citant l\\'indice décisif\"}',\n].join(\"\\n\");\n\nconst sleep = (ms: number) => new Promise((r) => setTimeout(r, ms));\nconst RATE = \"RATE_LIMIT\"; // marqueur : Gemini/Groq saturé, on réessaiera plus tard\n\nasync function callGroq(transcript: string) {\n const res = await fetch(\"https://api.groq.com/openai/v1/chat/completions\", {\n method: \"POST\",\n headers: { authorization: \"Bearer \" + GROQ, \"content-type\": \"application/json\" },\n body: JSON.stringify({\n model: MODEL, temperature: 0, response_format: { type: \"json_object\" },\n messages: [{ role: \"system\", content: SYSTEM }, { role: \"user\", content: \"Conversation :\\n\\n\" + transcript }],\n }),\n });\n if (res.status === 429 || res.status === 503) throw new Error(RATE); // pas d'attente : on passe et on réessaiera\n if (!res.ok) throw new Error(\"Groq \" + res.status + \" : \" + (await res.text()).slice(0, 160));\n const data = await res.json();\n return data?.choices?.[0]?.message?.content || \"\";\n}\n\nasync function callGemini(transcript: string) {\n const url = \"https://generativelanguage.googleapis.com/v1beta/models/\" + MODEL + \":generateContent?key=\" + GEMINI;\n const res = await fetch(url, {\n method: \"POST\", headers: { \"content-type\": \"application/json\" },\n body: JSON.stringify({\n system_instruction: { parts: [{ text: SYSTEM }] },\n contents: [{ role: \"user\", parts: [{ text: \"Conversation :\\n\\n\" + transcript }] }],\n generationConfig: { temperature: 0, responseMimeType: \"application/json\" },\n }),\n });\n if (res.status === 429 || res.status === 503) throw new Error(RATE); // saturé : on n'attend PAS, on réessaiera au prochain passage\n if (!res.ok) throw new Error(\"Gemini \" + res.status + \" : \" + (await res.text()).slice(0, 160));\n const data = await res.json();\n return (data?.candidates?.[0]?.content?.parts || []).map((p: any) => p.text || \"\").join(\"\");\n}\n\nasync function classify(transcript: string) {\n const raw = PROVIDER === \"gemini\" ? await callGemini(transcript) : await callGroq(transcript);\n const m = raw.match(/\\{[\\s\\S]*\\}/);\n if (!m) throw new Error(\"Réponse non JSON\");\n const out = JSON.parse(m[0]);\n const cat = [\"complet\", \"serviettes\", \"linge_lit\", \"aucun\", \"indetermine\"].includes(out.categorie) ? out.categorie : \"indetermine\";\n return {\n categorie: cat,\n montant_convenu: typeof out.montant_convenu === \"number\" ? out.montant_convenu : null,\n confiance: [\"haute\", \"moyenne\", \"basse\"].includes(out.confiance) ? out.confiance : \"basse\",\n justification: String(out.justification || \"\").slice(0, 300),\n };\n}\n\nasync function getBookingsCached() {\n // La liste des réservations (598) est lourde à récupérer : on la garde 15 min en cache\n // pour que chaque chargement de page soit rapide et ne dépasse pas le temps autorisé.\n const c = await cacheGet(\"bookings:v2\");\n if (c && c.ts && Date.now() - c.ts < 6 * 60 * 60 * 1000) return c; // gardé 6 h : la liste ne bouge pas souvent\n const [bookings, names] = await Promise.all([fetchAllBookings(), fetchPropertyNames()]);\n const val = { ts: Date.now(), bookings, names };\n await cacheSet(\"bookings:v2\", val);\n return val;\n}\n\n/* ---------- calcul d'une année ---------- */\nasync function compute(year: string, fresh: boolean) {\n const start = Date.now();\n const { bookings, names } = await getBookingsCached();\n const kept = bookings.filter((b: any) => {\n const dep = departure(b);\n if (!dep || String(dep).slice(0, 4) !== year) return false;\n if (b?.canceled_at || b?.is_deleted === true) return false; // annulée / supprimée\n const s = statusOf(b);\n if (EXCLUDED.some((x) => s.includes(x))) return false; // libellé d'annulation (FR ou EN)\n return true; // tout le reste est compté\n });\n\n const monthly = new Array(12).fill(0);\n const perAptMap: Record = {};\n const list: any[] = [];\n let total = 0;\n let pending = 0;\n let read = 0;\n let rateLimited = false;\n\n for (const b of kept) {\n const id = propId(b) || \"?\";\n const name = names[id] || (id !== \"?\" ? \"Logement \" + id : \"Logement inconnu\");\n const dep = String(departure(b));\n const guid = threadGuid(b);\n\n let cls: any = null;\n if (guid && !fresh) cls = await cacheGet(\"cls:\" + guid);\n\n if (!cls) {\n if (!guid) {\n cls = { categorie: \"indetermine\", montant_convenu: null, confiance: \"basse\", justification: \"Pas de conversation.\" };\n } else if (rateLimited || Date.now() - start > BUDGET_MS) {\n pending++;\n continue; // saturé ou temps écoulé : à lire au prochain passage, non compté\n } else {\n try {\n const thread = await lg(\"/messaging/\" + guid);\n cls = await classify(extractTranscript(thread));\n await cacheSet(\"cls:\" + guid, cls);\n read++;\n await sleep(700);\n } catch (e) {\n if (String((e as Error).message).includes(RATE)) {\n rateLimited = true; // Gemini saturé : on arrête de lire pour ce passage, on garde l'acquis\n pending++;\n continue;\n }\n cls = { categorie: \"indetermine\", montant_convenu: null, confiance: \"basse\", justification: \"Illisible : \" + String((e as Error).message).slice(0, 60) };\n }\n }\n }\n\n const amount = cls.montant_convenu != null && cls.montant_convenu > 0 ? cls.montant_convenu : (PRIX[cls.categorie] || 0);\n const aVerifier = cls.confiance !== \"haute\" || cls.categorie === \"indetermine\" || (amount === 0 && cls.categorie !== \"aucun\");\n\n const mIdx = parseInt(dep.slice(5, 7), 10) - 1;\n if (mIdx >= 0 && mIdx < 12) monthly[mIdx] += amount;\n total += amount;\n if (!perAptMap[id]) perAptMap[id] = { id, name, total: 0, count: 0 };\n perAptMap[id].total += amount;\n if (amount > 0) perAptMap[id].count += 1;\n\n list.push({\n id: String(pick(b, [\"id\", \"booking_id\"]) ?? dep + id),\n date: dep.slice(0, 10), aptName: name, guest: guestName(b),\n amount, categorie: cls.categorie, categorieLabel: LABELS[cls.categorie],\n aVerifier, justification: cls.justification,\n });\n }\n\n list.sort((a, b) => b.date.localeCompare(a.date));\n return {\n year, total, pending, read, rateLimited, totalKept: kept.length,\n perApt: Object.values(perAptMap).sort((a: any, b: any) => b.total - a.total),\n monthly,\n count: list.filter((e) => e.amount > 0).length,\n aVerifier: list.filter((e) => e.aVerifier).length,\n list, generatedAt: new Date().toISOString(),\n };\n}\n\n/* ---------- page HTML (rendu côté navigateur) ---------- */\nconst HTML = `\n\nComptes linge\n

Location saisonnière

Comptes linge

Recettes du linge, lues automatiquement dans les conversations Lodgify.

\n`;\n\n/* ---------- fonction pour le CRON (remplissage en arrière-plan) ----------\n Ajoute un trigger \"Cron\" dans Val Town pointant sur cette fonction : elle lit\n un lot de conversations à chaque exécution et met le résultat en cache. Au fil\n des exécutions, tout l'historique se remplit tout seul, sans clic. */\nexport async function backfill() {\n const y = new Date().getFullYear();\n const done: string[] = [];\n for (const year of [String(y), String(y - 1), String(y - 2)]) {\n try {\n const r = await compute(year, false);\n done.push(`${year}: ${r.count} lus, ${r.pending} en attente`);\n } catch (e) {\n done.push(`${year}: erreur ${(e as Error).message}`);\n }\n }\n return \"Backfill \" + new Date().toISOString() + \" — \" + done.join(\" | \");\n}\n\n/* ---------- point d'entrée HTTP ---------- */\nexport default async function (req: Request): Promise {\n // mot de passe optionnel (Basic Auth)\n if (PASSWORD) {\n const h = req.headers.get(\"authorization\") || \"\";\n let ok = false;\n if (h.startsWith(\"Basic \")) {\n try { const dec = atob(h.slice(6)); ok = dec.slice(dec.indexOf(\":\") + 1) === PASSWORD; } catch { /* noop */ }\n }\n if (!ok) return new Response(\"Accès protégé\", { status: 401, headers: { \"WWW-Authenticate\": 'Basic realm=\"Comptes linge\"' } });\n }\n\n const url = new URL(req.url);\n\n if (!LODGIFY) return Response.json({ error: \"LODGIFY_API_KEY manquante (Environment Variables).\" }, { status: 500 });\n\n if (url.searchParams.get(\"quota\") === \"1\") {\n // teste le quota Gemini avec UNE mini-requête, sans toucher au cache\n if (PROVIDER !== \"gemini\") return Response.json({ note: \"Fournisseur non-Gemini.\" });\n if (!GEMINI) return Response.json({ error: \"GEMINI_API_KEY manquante.\" }, { status: 500 });\n const u = \"https://generativelanguage.googleapis.com/v1beta/models/\" + MODEL + \":generateContent?key=\" + GEMINI;\n const res = await fetch(u, {\n method: \"POST\", headers: { \"content-type\": \"application/json\" },\n body: JSON.stringify({ contents: [{ role: \"user\", parts: [{ text: \"dis OK\" }] }], generationConfig: { maxOutputTokens: 5 } }),\n });\n const body = await res.text();\n let verdict: string;\n if (res.status === 429) verdict = \"❌ QUOTA ÉPUISÉ (limite Gemini atteinte). Réessaie plus tard / demain.\";\n else if (res.status === 404) verdict = \"⚠️ Nom de modèle non reconnu (404). Vérifie CLASSIFIER_MODEL.\";\n else if (res.ok) verdict = \"✅ QUOTA OK — Gemini répond, tu peux lire tes conversations.\";\n else verdict = \"⚠️ Réponse inattendue (code \" + res.status + \").\";\n return Response.json({ verdict, model: MODEL, httpStatus: res.status, detail: body.slice(0, 300) });\n }\n\n if (url.searchParams.get(\"thread\")) {\n try { return Response.json(await lg(\"/messaging/\" + url.searchParams.get(\"thread\"))); }\n catch (e) { return Response.json({ error: String((e as Error).message) }, { status: 502 }); }\n }\n if (url.searchParams.get(\"debug\") === \"1\") {\n try {\n const { bookings, names } = await getBookingsCached();\n const parAnnee: Record = {};\n const statuts: Record = {};\n for (const b of bookings) {\n const y = String(departure(b) ?? \"\").slice(0, 4) || \"?\";\n parAnnee[y] = (parAnnee[y] || 0) + 1;\n const s = String(pick(b, [\"status\", \"state\"]) ?? \"?\");\n statuts[s] = (statuts[s] || 0) + 1;\n }\n return Response.json({ totalBookings: bookings.length, parAnnee, statuts, propertyNames: names });\n } catch (e) { return Response.json({ error: String((e as Error).message) }, { status: 502 }); }\n }\n\n if (url.searchParams.get(\"reset\") === \"1\") {\n try {\n await ensureTable();\n await sqlite.execute(\"DELETE FROM linge_cache WHERE k LIKE 'cls:%'\");\n return Response.json({ ok: true });\n } catch (e) { return Response.json({ error: String((e as Error).message) }, { status: 502 }); }\n }\n\n if (url.searchParams.get(\"data\") === \"1\") {\n const llmKey = PROVIDER === \"gemini\" ? GEMINI : GROQ;\n if (!llmKey) return Response.json({ error: (PROVIDER === \"gemini\" ? \"GEMINI_API_KEY\" : \"GROQ_API_KEY\") + \" manquante (Environment Variables).\" }, { status: 500 });\n const year = url.searchParams.get(\"year\") || String(new Date().getFullYear());\n const fresh = url.searchParams.get(\"fresh\") === \"1\";\n try { return Response.json(await compute(year, fresh)); }\n catch (e) { return Response.json({ error: String((e as Error).message) }, { status: 502 }); }\n }\n\n return new Response(HTML, { headers: { \"content-type\": \"text/html; charset=utf-8\" } });\n}","// Comptes linge — un seul fichier, pour Val Town (https://val.town)\n// À coller dans un nouveau \"HTTP val\". Règle ensuite les variables dans\n// l'onglet \"Environment Variables\" (barre de gauche).\n//\n// Variables :\n// LODGIFY_API_KEY (obligatoire) Lodgify -> Réglages -> Public API\n// GROQ_API_KEY (obligatoire) console.groq.com\n// LINGE_PASSWORD (conseillé) mot de passe pour ouvrir la page\n// PRIX_COMPLET / PRIX_SERVIETTES / PRIX_LINGE_LIT (facultatif : repli si aucun montant dans le chat)\n// CLASSIFIER_MODEL (facultatif, défaut llama-3.3-70b-versatile)\n\nimport { sqlite } from \"https://esm.town/v/std/sqlite\";\n\nconst LODGIFY = Deno.env.get(\"LODGIFY_API_KEY\");\nconst GROQ = Deno.env.get(\"GROQ_API_KEY\");\nconst GEMINI = Deno.env.get(\"GEMINI_API_KEY\");\nconst PASSWORD = Deno.env.get(\"LINGE_PASSWORD\") || \"\";\n// Détection automatique : si tu mets une clé Gemini, il l'utilise ; sinon Groq.\nconst PROVIDER = (Deno.env.get(\"LLM_PROVIDER\") || (GEMINI ? \"gemini\" : \"groq\")).toLowerCase();\nconst MODEL = Deno.env.get(\"CLASSIFIER_MODEL\") || (PROVIDER === \"gemini\" ? \"gemini-2.5-flash\" : \"llama-3.3-70b-versatile\");\nconst BUDGET_MS = 5000; // très court : chaque requête finit vite, jamais de 502 (lecture par mini-tranches)\n\nconst num = (v: string | undefined, d: number) => {\n const n = parseFloat(String(v ?? \"\").replace(\",\", \".\"));\n return isNaN(n) ? d : n;\n};\nconst PRIX: Record = {\n complet: num(Deno.env.get(\"PRIX_COMPLET\"), 0),\n serviettes: num(Deno.env.get(\"PRIX_SERVIETTES\"), 0),\n linge_lit: num(Deno.env.get(\"PRIX_LINGE_LIT\"), 0),\n aucun: 0,\n indetermine: 0,\n};\nconst LABELS: Record = {\n complet: \"Linge complet\",\n serviettes: \"Serviettes\",\n linge_lit: \"Linge de lit\",\n aucun: \"Aucun\",\n indetermine: \"À vérifier\",\n};\n// On ne rejette QUE les réservations clairement annulées/refusées (français et anglais).\n// Tout le reste (\"Réservé\", \"Booked\"…) est compté : mieux vaut inclure que perdre un séjour.\nconst EXCLUDED = [\n \"declined\", \"refusé\", \"refuse\",\n \"cancelled\", \"canceled\", \"annulé\", \"annule\",\n \"trash\", \"corbeille\",\n \"deleted\", \"supprimé\", \"supprime\",\n];\n\n/* ---------- cache SQLite ---------- */\nlet tableReady = false;\nasync function ensureTable() {\n if (tableReady) return;\n await sqlite.execute(\"CREATE TABLE IF NOT EXISTS linge_cache (k TEXT PRIMARY KEY, v TEXT)\");\n tableReady = true;\n}\nasync function cacheGet(k: string) {\n await ensureTable();\n const r = await sqlite.execute({ sql: \"SELECT v FROM linge_cache WHERE k = ?\", args: [k] });\n const row = r.rows?.[0];\n if (!row) return null;\n try { return JSON.parse(row[0] as string); } catch { return null; }\n}\nasync function cacheSet(k: string, v: unknown) {\n await ensureTable();\n await sqlite.execute({ sql: \"INSERT OR REPLACE INTO linge_cache (k, v) VALUES (?, ?)\", args: [k, JSON.stringify(v)] });\n}\n\n/* ---------- Lodgify ---------- */\nconst API = \"https://api.lodgify.com/v2\";\nasync function lg(path: string, params: Record = {}) {\n const url = new URL(API + path);\n for (const [k, v] of Object.entries(params)) if (v != null) url.searchParams.set(k, String(v));\n const res = await fetch(url.toString(), { headers: { \"X-ApiKey\": LODGIFY as string, accept: \"application/json\" } });\n if (!res.ok) throw new Error(\"Lodgify \" + res.status + \" sur \" + path + \" : \" + (await res.text().catch(() => \"\")).slice(0, 160));\n return res.json();\n}\n/* ---------- Synchronisation PROGRESSIVE des réservations ----------\n Récupérer ~600 réservations d'un coup dépasse le temps autorisé (erreur 502).\n On récupère quelques pages par requête, on sauvegarde l'avancement, et on\n reprend là où on s'était arrêté au chargement suivant. */\nconst FILTERS = [\"Upcoming\", \"Current\", \"Historic\"];\n\n// On ne garde que les champs utiles : la liste reste légère à stocker.\nfunction slim(b: any) {\n return {\n id: String(b?.id ?? b?.booking_id ?? \"\"),\n departure: departure(b),\n property_id: propId(b),\n guest: guestName(b),\n status: String(pick(b, [\"status\", \"state\"]) ?? \"\"),\n canceled_at: b?.canceled_at ?? null,\n is_deleted: b?.is_deleted ?? false,\n thread_uid: threadGuid(b),\n };\n}\n\nasync function syncBookings() {\n const state = (await cacheGet(\"sync:v3\")) || { fi: 0, page: 1, done: false, items: {} as Record };\n if (state.done) return state;\n\n const t0 = Date.now();\n const size = 50; // maximum accepté par Lodgify\n\n while (state.fi < FILTERS.length && Date.now() - t0 < 6000) { // 6 s max, pour ne jamais dépasser\n let data: any;\n try {\n data = await lg(\"/reservations/bookings\", {\n page: state.page, size, stayFilter: FILTERS[state.fi],\n includeExternal: true, trash: false, includeCount: false,\n });\n } catch {\n state.fi++; state.page = 1; continue;\n }\n const items = data?.items ?? data?.bookings ?? (Array.isArray(data) ? data : []);\n for (const b of items) {\n const s = slim(b);\n if (s.id) state.items[s.id] = s;\n }\n if (items.length < size) { state.fi++; state.page = 1; } // dernière page de ce filtre\n else state.page++;\n }\n\n if (state.fi >= FILTERS.length) state.done = true;\n await cacheSet(\"sync:v3\", state);\n return state;\n}\n\nasync function fetchPropertyNames() {\n const map: Record = {};\n try {\n const data = await lg(\"/properties\", { page: 1, size: 50 });\n const items = data?.items ?? data?.properties ?? (Array.isArray(data) ? data : []);\n for (const p of items) {\n const id = String(p.id ?? p.property_id ?? p.house_id ?? \"\");\n if (id) map[id] = p.name ?? p.title ?? (\"Logement \" + id);\n }\n } catch { /* on retombera sur l'ID */ }\n return map;\n}\n\nasync function getPropertyNamesCached() {\n const c = await cacheGet(\"props:v1\");\n if (c && c.ts && Date.now() - c.ts < 24 * 60 * 60 * 1000) return c.names;\n const names = await fetchPropertyNames();\n await cacheSet(\"props:v1\", { ts: Date.now(), names });\n return names;\n}\n\nconst pick = (o: any, ks: string[]) => { for (const k of ks) if (o?.[k] != null && o[k] !== \"\") return o[k]; return undefined; };\nconst propId = (b: any) => String(pick(b, [\"property_id\", \"house_id\", \"rental_id\", \"propertyId\"]) ?? b?.rooms?.[0]?.property_id ?? \"\");\nconst departure = (b: any) => pick(b, [\"departure\", \"date_departure\", \"departureDate\", \"checkOut\", \"check_out\", \"end\"]);\nconst guestName = (b: any) => b?.guest?.name ?? pick(b, [\"guest_name\", \"guestName\"]) ?? \"\";\nconst statusOf = (b: any) => String(pick(b, [\"status\", \"state\"]) ?? \"\").toLowerCase();\nconst threadGuid = (b: any) => pick(b, [\"thread_uid\", \"thread_guid\", \"threadGuid\", \"messaging_thread_guid\", \"conversation_guid\", \"guid\"]);\n\nfunction extractTranscript(thread: any) {\n const msgs = thread?.messages ?? thread?.Messages ?? thread?.thread?.messages ?? [];\n if (Array.isArray(msgs) && msgs.length) {\n const lines = msgs.map((m: any) => {\n const text = pick(m, [\"message\", \"content\", \"text\", \"body\", \"Message\"]);\n if (!text) return \"\";\n const src = String(pick(m, [\"source\", \"from\", \"author\", \"sender\", \"direction\"]) ?? \"\").toLowerCase();\n const host = m.is_host ?? m.isHost ?? src.includes(\"host\") ?? src.includes(\"out\");\n return (host ? \"Hôte\" : \"Voyageur\") + \": \" + String(text).replace(/\\s+/g, \" \").trim();\n }).filter(Boolean);\n if (lines.length) return lines.join(\"\\n\").slice(0, 7000);\n }\n return JSON.stringify(thread).slice(0, 7000);\n}\n\n/* ---------- lecture par l'IA ---------- */\nconst SYSTEM = [\n \"Tu lis une conversation en français entre l'hôte d'une location saisonnière et un voyageur.\",\n \"Lis et COMPRENDS toute la conversation. Ton but : déterminer ce que le voyageur a réellement pris comme linge de maison payant (en supplément, réglé en espèces au départ) ET la somme à compter.\",\n \"\",\n \"COMMENT SAVOIR SI L'OPTION EST PRISE (règle essentielle) :\",\n \"- L'hôte ne confirme un montant à régler QUE lorsque le voyageur a accepté l'option. Sa phrase de confirmation ressemble à : « il faudra laisser X euros sur la table lors de votre départ » — mais comprends l'INTENTION, pas les mots exacts (les formulations varient).\",\n \"- Si cette confirmation de montant par l'hôte est présente → l'option est PRISE, et le montant à compter est CE montant-là.\",\n \"- Si elle est ABSENTE → l'option n'a pas été prise → categorie \\\"aucun\\\", montant 0. C'est le cas si le voyageur refuse, dit qu'il apporte son propre linge/ses draps/ses serviettes, ne répond pas, ou si le sujet n'est jamais confirmé.\",\n \"\",\n \"INTERDICTION IMPORTANTE :\",\n \"- N'invente JAMAIS un montant à partir d'un chiffre qui traîne (un prix général évoqué, un numéro, une date, un tarif de ménage, un autre sujet). Un montant ne compte QUE s'il est clairement rattaché à la confirmation du linge par l'hôte.\",\n \"- Le dernier choix exprimé par le voyageur l'emporte toujours (s'il accepte puis se rétracte → aucun).\",\n \"\",\n \"Catégories :\",\n '- \"complet\" : linge complet (draps ET serviettes).',\n '- \"serviettes\" : uniquement les serviettes.',\n '- \"linge_lit\" : uniquement les draps / linge de lit.',\n '- \"aucun\" : rien de payant pris (refus, apporte le sien, ou pas de confirmation de montant).',\n '- \"indetermine\" : la conversation parle du linge mais il est vraiment impossible de trancher.',\n \"\",\n \"Montant :\",\n '- \"montant_convenu\" = la somme EN EUROS que l\\'hôte confirme à laisser au départ. 0 si aucun.',\n \"- CE MONTANT SE TROUVE DANS LA PHRASE DE CONFIRMATION DE L'HÔTE, du type « il faudra laisser X euros sur la table lors de votre départ ». Prends CE chiffre-là en priorité absolue.\",\n \"- Lis le nombre EXACT, même collé ou sans espace : « 45euros », « 45 euros », « 45€ » valent tous 45. Ne le confonds jamais avec un autre chiffre de la conversation (heure, code d'accès, prix du séjour…).\",\n \"- S'il y a plusieurs montants, celui de la phrase de confirmation finale de l'hôte l'emporte. Si aucune phrase de confirmation de montant n'existe → \\\"aucun\\\", montant 0.\",\n \"\",\n \"Confiance : \\\"haute\\\" si c'est net (refus clair, ou confirmation de montant claire) ; \\\"moyenne\\\"/\\\"basse\\\" si ça demande interprétation.\",\n \"\",\n 'Réponds UNIQUEMENT en JSON : {\"categorie\":\"complet|serviettes|linge_lit|aucun|indetermine\",\"montant_convenu\":nombre ou null,\"confiance\":\"haute|moyenne|basse\",\"justification\":\"courte raison, en citant l\\'indice décisif\"}',\n].join(\"\\n\");\n\nconst sleep = (ms: number) => new Promise((r) => setTimeout(r, ms));\nconst RATE = \"RATE_LIMIT\"; // marqueur : Gemini/Groq saturé, on réessaiera plus tard\n\nasync function callGroq(transcript: string) {\n const res = await fetch(\"https://api.groq.com/openai/v1/chat/completions\", {\n method: \"POST\",\n headers: { authorization: \"Bearer \" + GROQ, \"content-type\": \"application/json\" },\n body: JSON.stringify({\n model: MODEL, temperature: 0, response_format: { type: \"json_object\" },\n messages: [{ role: \"system\", content: SYSTEM }, { role: \"user\", content: \"Conversation :\\n\\n\" + transcript }],\n }),\n });\n if (res.status === 429 || res.status === 503) throw new Error(RATE); // pas d'attente : on passe et on réessaiera\n if (!res.ok) throw new Error(\"Groq \" + res.status + \" : \" + (await res.text()).slice(0, 160));\n const data = await res.json();\n return data?.choices?.[0]?.message?.content || \"\";\n}\n\nasync function callGemini(transcript: string) {\n const url = \"https://generativelanguage.googleapis.com/v1beta/models/\" + MODEL + \":generateContent?key=\" + GEMINI;\n const res = await fetch(url, {\n method: \"POST\", headers: { \"content-type\": \"application/json\" },\n body: JSON.stringify({\n system_instruction: { parts: [{ text: SYSTEM }] },\n contents: [{ role: \"user\", parts: [{ text: \"Conversation :\\n\\n\" + transcript }] }],\n generationConfig: { temperature: 0, responseMimeType: \"application/json\" },\n }),\n });\n if (res.status === 429 || res.status === 503) throw new Error(RATE); // saturé : on n'attend PAS, on réessaiera au prochain passage\n if (!res.ok) throw new Error(\"Gemini \" + res.status + \" : \" + (await res.text()).slice(0, 160));\n const data = await res.json();\n return (data?.candidates?.[0]?.content?.parts || []).map((p: any) => p.text || \"\").join(\"\");\n}\n\nasync function classify(transcript: string) {\n const raw = PROVIDER === \"gemini\" ? await callGemini(transcript) : await callGroq(transcript);\n const m = raw.match(/\\{[\\s\\S]*\\}/);\n if (!m) throw new Error(\"Réponse non JSON\");\n const out = JSON.parse(m[0]);\n const cat = [\"complet\", \"serviettes\", \"linge_lit\", \"aucun\", \"indetermine\"].includes(out.categorie) ? out.categorie : \"indetermine\";\n return {\n categorie: cat,\n montant_convenu: typeof out.montant_convenu === \"number\" ? out.montant_convenu : null,\n confiance: [\"haute\", \"moyenne\", \"basse\"].includes(out.confiance) ? out.confiance : \"basse\",\n justification: String(out.justification || \"\").slice(0, 300),\n };\n}\n\n/* ---------- calcul d'une année ---------- */\nasync function compute(year: string, fresh: boolean) {\n const start = Date.now();\n const sync = await syncBookings(); // étape 1 : récupérer l'historique par morceaux\n const names = await getPropertyNamesCached();\n const all = Object.values(sync.items) as any[];\n\n const kept = all.filter((b: any) => {\n const dep = b.departure;\n if (!dep || String(dep).slice(0, 4) !== year) return false;\n if (b.canceled_at || b.is_deleted === true) return false; // annulée / supprimée\n const s = String(b.status || \"\").toLowerCase();\n if (EXCLUDED.some((x) => s.includes(x))) return false; // annulation (FR ou EN)\n return true; // tout le reste est compté\n });\n\n const monthly = new Array(12).fill(0);\n const perAptMap: Record = {};\n const list: any[] = [];\n let total = 0;\n let pending = 0;\n let read = 0;\n let rateLimited = false;\n\n for (const b of kept) {\n const id = b.property_id || \"?\";\n const name = names[id] || (id !== \"?\" ? \"Logement \" + id : \"Logement inconnu\");\n const dep = String(b.departure);\n const guid = b.thread_uid;\n\n let cls: any = null;\n if (guid && !fresh) cls = await cacheGet(\"cls:\" + guid);\n\n if (!cls) {\n if (!guid) {\n cls = { categorie: \"indetermine\", montant_convenu: null, confiance: \"basse\", justification: \"Pas de conversation.\" };\n } else if (rateLimited || Date.now() - start > BUDGET_MS) {\n pending++;\n continue; // saturé ou temps écoulé : à lire au prochain passage, non compté\n } else {\n try {\n const thread = await lg(\"/messaging/\" + guid);\n cls = await classify(extractTranscript(thread));\n await cacheSet(\"cls:\" + guid, cls);\n read++;\n await sleep(400);\n } catch (e) {\n if (String((e as Error).message).includes(RATE)) {\n rateLimited = true; // Gemini saturé : on arrête de lire pour ce passage, on garde l'acquis\n pending++;\n continue;\n }\n cls = { categorie: \"indetermine\", montant_convenu: null, confiance: \"basse\", justification: \"Illisible : \" + String((e as Error).message).slice(0, 60) };\n }\n }\n }\n\n const amount = cls.montant_convenu != null && cls.montant_convenu > 0 ? cls.montant_convenu : (PRIX[cls.categorie] || 0);\n const aVerifier = cls.confiance !== \"haute\" || cls.categorie === \"indetermine\" || (amount === 0 && cls.categorie !== \"aucun\");\n\n const mIdx = parseInt(dep.slice(5, 7), 10) - 1;\n if (mIdx >= 0 && mIdx < 12) monthly[mIdx] += amount;\n total += amount;\n if (!perAptMap[id]) perAptMap[id] = { id, name, total: 0, count: 0 };\n perAptMap[id].total += amount;\n if (amount > 0) perAptMap[id].count += 1;\n\n list.push({\n id: b.id || (dep + id),\n date: dep.slice(0, 10), aptName: name, guest: b.guest,\n amount, categorie: cls.categorie, categorieLabel: LABELS[cls.categorie],\n aVerifier, justification: cls.justification,\n });\n }\n\n list.sort((a, b) => b.date.localeCompare(a.date));\n return {\n year, total, pending, read, rateLimited, totalKept: kept.length,\n syncDone: sync.done, syncCount: Object.keys(sync.items).length,\n perApt: Object.values(perAptMap).sort((a: any, b: any) => b.total - a.total),\n monthly,\n count: list.filter((e) => e.amount > 0).length,\n aVerifier: list.filter((e) => e.aVerifier).length,\n list, generatedAt: new Date().toISOString(),\n };\n}\n\n/* ---------- page HTML (rendu côté navigateur) ---------- */\nconst HTML = `\n\nComptes linge\n

Location saisonnière

Comptes linge

Recettes du linge, lues automatiquement dans les conversations Lodgify.

Diff · v18