[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_155":156,"_157":158},"routes/_app.x.$handle.$name",{"_96":95,"_32":45,"_105":86,"_27":53,"_13":14,"_106":-5,"_11":107,"_108":109,"_110":111,"_112":113,"_114":115,"_20":-5,"_116":-5,"_117":-5,"_118":25,"_119":120,"_121":58,"_122":-5,"_123":-5,"_124":125},"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",10,"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\"))\n .toLowerCase();\nconst MODEL = Deno.env.get(\"CLASSIFIER_MODEL\") ||\n (PROVIDER === \"gemini\" ? \"gemini-2.5-flash\" : \"llama-3.3-70b-versatile\");\nconst BUDGET_MS = 20000; // lecture par lots pour ne pas dépasser le temps gratuit\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};\nconst EXCLUDED = [\n \"declined\",\n \"cancelled\",\n \"canceled\",\n \"tentative\",\n \"trash\",\n \"open\",\n];\n\n/* ---------- cache SQLite ---------- */\nlet tableReady = false;\nasync function ensureTable() {\n if (tableReady) return;\n await sqlite.execute(\n \"CREATE TABLE IF NOT EXISTS linge_cache (k TEXT PRIMARY KEY, v TEXT)\",\n );\n tableReady = true;\n}\nasync function cacheGet(k: string) {\n await ensureTable();\n const r = await sqlite.execute({\n sql: \"SELECT v FROM linge_cache WHERE k = ?\",\n args: [k],\n });\n const row = r.rows?.[0];\n if (!row) return null;\n try {\n return JSON.parse(row[0] as string);\n } catch {\n return null;\n }\n}\nasync function cacheSet(k: string, v: unknown) {\n await ensureTable();\n await sqlite.execute({\n sql: \"INSERT OR REPLACE INTO linge_cache (k, v) VALUES (?, ?)\",\n args: [k, JSON.stringify(v)],\n });\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)) {\n if (v != null) url.searchParams.set(k, String(v));\n }\n const res = await fetch(url.toString(), {\n headers: { \"X-ApiKey\": LODGIFY as string, accept: \"application/json\" },\n });\n if (!res.ok) {\n throw new Error(\n \"Lodgify \" + res.status + \" sur \" + path + \" : \" +\n (await res.text().catch(() => \"\")).slice(0, 160),\n );\n }\n return res.json();\n}\nasync function fetchAllBookings() {\n // Lodgify ne renvoie que les séjours \"Current\" par défaut.\n // On interroge passé + présent + futur, et on inclut les résas Airbnb/Booking.\n const byId = new Map();\n const filters = [\"Upcoming\", \"Current\", \"Historic\"];\n const size = 50;\n for (const stayFilter of filters) {\n for (let page = 1; page <= 80; page++) {\n let data: any;\n try {\n data = await lg(\"/reservations/bookings\", {\n page,\n size,\n stayFilter,\n includeExternal: true,\n trash: false,\n includeCount: false,\n });\n } catch {\n break; // filtre non supporté ou erreur : on passe au suivant\n }\n const items = data?.items ?? data?.bookings ??\n (Array.isArray(data) ? data : []);\n for (const b of items) {\n const id = String(\n b?.id ?? b?.booking_id ?? (b?.arrival + \"_\" + b?.property_id),\n );\n byId.set(id, b);\n }\n if (items.length < size) break;\n }\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 ??\n (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[]) => {\n for (const k of ks) if (o?.[k] != null && o[k] !== \"\") return o[k];\n return undefined;\n};\nconst propId = (b: any) =>\n String(\n pick(b, [\"property_id\", \"house_id\", \"rental_id\", \"propertyId\"]) ??\n b?.rooms?.[0]?.property_id ?? \"\",\n );\nconst departure = (b: any) =>\n pick(b, [\n \"departure\",\n \"date_departure\",\n \"departureDate\",\n \"checkOut\",\n \"check_out\",\n \"end\",\n ]);\nconst guestName = (b: any) =>\n b?.guest?.name ?? pick(b, [\"guest_name\", \"guestName\"]) ?? \"\";\nconst statusOf = (b: any) =>\n String(pick(b, [\"status\", \"state\"]) ?? \"\").toLowerCase();\nconst threadGuid = (b: any) =>\n pick(b, [\n \"thread_uid\",\n \"thread_guid\",\n \"threadGuid\",\n \"messaging_thread_guid\",\n \"conversation_guid\",\n \"guid\",\n ]);\n\nfunction extractTranscript(thread: any) {\n const msgs = thread?.messages ?? thread?.Messages ??\n 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(\n pick(m, [\"source\", \"from\", \"author\", \"sender\", \"direction\"]) ?? \"\",\n ).toLowerCase();\n const host = m.is_host ?? m.isHost ?? src.includes(\"host\") ??\n src.includes(\"out\");\n return (host ? \"Hôte\" : \"Voyageur\") + \": \" +\n 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 confirmée par l\\'hôte pour le linge pris. 0 si aucun. null seulement si option manifestement prise mais montant illisible.',\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));\n\nasync function callGroq(transcript: string) {\n for (let attempt = 0; attempt < 4; attempt++) {\n const res = await fetch(\"https://api.groq.com/openai/v1/chat/completions\", {\n method: \"POST\",\n headers: {\n authorization: \"Bearer \" + GROQ,\n \"content-type\": \"application/json\",\n },\n body: JSON.stringify({\n model: MODEL,\n temperature: 0,\n response_format: { type: \"json_object\" },\n messages: [{ role: \"system\", content: SYSTEM }, {\n role: \"user\",\n content: \"Conversation :\\n\\n\" + transcript,\n }],\n }),\n });\n if (res.status === 429 || res.status === 503) {\n await sleep(3000 * (attempt + 1));\n continue;\n }\n if (!res.ok) {\n throw new Error(\n \"Groq \" + res.status + \" : \" + (await res.text()).slice(0, 160),\n );\n }\n const data = await res.json();\n return data?.choices?.[0]?.message?.content || \"\";\n }\n throw new Error(\"Groq 429 (limite de vitesse) après plusieurs essais\");\n}\n\nasync function callGemini(transcript: string) {\n const url = \"https://generativelanguage.googleapis.com/v1beta/models/\" +\n MODEL + \":generateContent?key=\" + GEMINI;\n for (let attempt = 0; attempt < 4; attempt++) {\n const res = await fetch(url, {\n method: \"POST\",\n headers: { \"content-type\": \"application/json\" },\n body: JSON.stringify({\n system_instruction: { parts: [{ text: SYSTEM }] },\n contents: [{\n role: \"user\",\n parts: [{ text: \"Conversation :\\n\\n\" + transcript }],\n }],\n generationConfig: {\n temperature: 0,\n responseMimeType: \"application/json\",\n },\n }),\n });\n if (res.status === 429 || res.status === 503) {\n await sleep(4000 * (attempt + 1));\n continue;\n } // limite de vitesse : on attend puis on réessaie\n if (!res.ok) {\n throw new Error(\n \"Gemini \" + res.status + \" : \" + (await res.text()).slice(0, 160),\n );\n }\n const data = await res.json();\n return (data?.candidates?.[0]?.content?.parts || []).map((p: any) =>\n p.text || \"\"\n ).join(\"\");\n }\n throw new Error(\"Gemini 429 (limite de vitesse) après plusieurs essais\");\n}\n\nasync function classify(transcript: string) {\n const raw = PROVIDER === \"gemini\"\n ? await callGemini(transcript)\n : 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 =\n [\"complet\", \"serviettes\", \"linge_lit\", \"aucun\", \"indetermine\"].includes(\n out.categorie,\n )\n ? out.categorie\n : \"indetermine\";\n return {\n categorie: cat,\n montant_convenu: typeof out.montant_convenu === \"number\"\n ? out.montant_convenu\n : null,\n confiance: [\"haute\", \"moyenne\", \"basse\"].includes(out.confiance)\n ? out.confiance\n : \"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 [bookings, names] = await Promise.all([\n fetchAllBookings(),\n fetchPropertyNames(),\n ]);\n const kept = bookings.filter((b) => {\n const dep = departure(b);\n return dep && String(dep).slice(0, 4) === year &&\n !EXCLUDED.includes(statusOf(b));\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 const start = Date.now();\n\n for (const b of kept) {\n const id = propId(b) || \"?\";\n const name = names[id] ||\n (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 = {\n categorie: \"indetermine\",\n montant_convenu: null,\n confiance: \"basse\",\n justification: \"Pas de conversation.\",\n };\n } else if (Date.now() - start > BUDGET_MS) {\n pending++;\n continue; // pas encore lu : non compté, on reprendra au prochain chargement\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(1200); // petit délai pour rester sous la limite gratuite\n } catch (e) {\n cls = {\n categorie: \"indetermine\",\n montant_convenu: null,\n confiance: \"basse\",\n justification: \"Illisible : \" +\n String((e as Error).message).slice(0, 60),\n };\n }\n }\n }\n\n const amount = cls.montant_convenu != null && cls.montant_convenu > 0\n ? cls.montant_convenu\n : (PRIX[cls.categorie] || 0);\n const aVerifier = cls.confiance !== \"haute\" ||\n cls.categorie === \"indetermine\" ||\n (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),\n aptName: name,\n guest: guestName(b),\n amount,\n categorie: cls.categorie,\n categorieLabel: LABELS[cls.categorie],\n aVerifier,\n justification: cls.justification,\n });\n }\n\n list.sort((a, b) => b.date.localeCompare(a.date));\n return {\n year,\n total,\n pending,\n read,\n totalKept: kept.length,\n perApt: Object.values(perAptMap).sort((a: any, b: any) =>\n b.total - a.total\n ),\n monthly,\n count: list.filter((e) => e.amount > 0).length,\n aVerifier: list.filter((e) => e.aVerifier).length,\n list,\n 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 {\n const dec = atob(h.slice(6));\n ok = dec.slice(dec.indexOf(\":\") + 1) === PASSWORD;\n } catch { /* noop */ }\n }\n if (!ok) {\n return new Response(\"Accès protégé\", {\n status: 401,\n headers: { \"WWW-Authenticate\": 'Basic realm=\"Comptes linge\"' },\n });\n }\n }\n\n const url = new URL(req.url);\n\n if (!LODGIFY) {\n return Response.json({\n error: \"LODGIFY_API_KEY manquante (Environment Variables).\",\n }, { status: 500 });\n }\n\n if (url.searchParams.get(\"thread\")) {\n try {\n return Response.json(\n await lg(\"/messaging/\" + url.searchParams.get(\"thread\")),\n );\n } catch (e) {\n return Response.json({ error: String((e as Error).message) }, {\n status: 502,\n });\n }\n }\n if (url.searchParams.get(\"debug\") === \"1\") {\n try {\n const [b, n] = await Promise.all([\n fetchAllBookings(),\n fetchPropertyNames(),\n ]);\n return Response.json({\n totalBookings: b.length,\n sample: b[0] ?? null,\n propertyNames: n,\n });\n } catch (e) {\n return Response.json({ error: String((e as Error).message) }, {\n status: 502,\n });\n }\n }\n\n if (url.searchParams.get(\"data\") === \"1\") {\n const llmKey = PROVIDER === \"gemini\" ? GEMINI : GROQ;\n if (!llmKey) {\n return Response.json({\n error: (PROVIDER === \"gemini\" ? \"GEMINI_API_KEY\" : \"GROQ_API_KEY\") +\n \" manquante (Environment Variables).\",\n }, { status: 500 });\n }\n const year = url.searchParams.get(\"year\") ||\n String(new Date().getFullYear());\n const fresh = url.searchParams.get(\"fresh\") === \"1\";\n try {\n return Response.json(await compute(year, fresh));\n } catch (e) {\n return Response.json({ error: String((e as Error).message) }, {\n status: 502,\n });\n }\n }\n\n return new Response(HTML, {\n headers: { \"content-type\": \"text/html; charset=utf-8\" },\n });\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\"))\n .toLowerCase();\nconst MODEL = Deno.env.get(\"CLASSIFIER_MODEL\") ||\n (PROVIDER === \"gemini\" ? \"gemini-2.5-flash\" : \"llama-3.3-70b-versatile\");\nconst BUDGET_MS = 20000; // lecture par lots pour ne pas dépasser le temps gratuit\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};\nconst EXCLUDED = [\n \"declined\",\n \"cancelled\",\n \"canceled\",\n \"tentative\",\n \"trash\",\n \"open\",\n];\n\n/* ---------- cache SQLite ---------- */\nlet tableReady = false;\nasync function ensureTable() {\n if (tableReady) return;\n await sqlite.execute(\n \"CREATE TABLE IF NOT EXISTS linge_cache (k TEXT PRIMARY KEY, v TEXT)\",\n );\n tableReady = true;\n}\nasync function cacheGet(k: string) {\n await ensureTable();\n const r = await sqlite.execute({\n sql: \"SELECT v FROM linge_cache WHERE k = ?\",\n args: [k],\n });\n const row = r.rows?.[0];\n if (!row) return null;\n try {\n return JSON.parse(row[0] as string);\n } catch {\n return null;\n }\n}\nasync function cacheSet(k: string, v: unknown) {\n await ensureTable();\n await sqlite.execute({\n sql: \"INSERT OR REPLACE INTO linge_cache (k, v) VALUES (?, ?)\",\n args: [k, JSON.stringify(v)],\n });\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)) {\n if (v != null) url.searchParams.set(k, String(v));\n }\n const res = await fetch(url.toString(), {\n headers: { \"X-ApiKey\": LODGIFY as string, accept: \"application/json\" },\n });\n if (!res.ok) {\n throw new Error(\n \"Lodgify \" + res.status + \" sur \" + path + \" : \" +\n (await res.text().catch(() => \"\")).slice(0, 160),\n );\n }\n return res.json();\n}\nasync function fetchAllBookings() {\n // Lodgify ne renvoie que les séjours \"Current\" par défaut.\n // On interroge passé + présent + futur, et on inclut les résas Airbnb/Booking.\n const byId = new Map();\n const filters = [\"Upcoming\", \"Current\", \"Historic\"];\n const size = 50;\n for (const stayFilter of filters) {\n for (let page = 1; page <= 80; page++) {\n let data: any;\n try {\n data = await lg(\"/reservations/bookings\", {\n page,\n size,\n stayFilter,\n includeExternal: true,\n trash: false,\n includeCount: false,\n });\n } catch {\n break; // filtre non supporté ou erreur : on passe au suivant\n }\n const items = data?.items ?? data?.bookings ??\n (Array.isArray(data) ? data : []);\n for (const b of items) {\n const id = String(\n b?.id ?? b?.booking_id ?? (b?.arrival + \"_\" + b?.property_id),\n );\n byId.set(id, b);\n }\n if (items.length < size) break;\n }\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 ??\n (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[]) => {\n for (const k of ks) if (o?.[k] != null && o[k] !== \"\") return o[k];\n return undefined;\n};\nconst propId = (b: any) =>\n String(\n pick(b, [\"property_id\", \"house_id\", \"rental_id\", \"propertyId\"]) ??\n b?.rooms?.[0]?.property_id ?? \"\",\n );\nconst departure = (b: any) =>\n pick(b, [\n \"departure\",\n \"date_departure\",\n \"departureDate\",\n \"checkOut\",\n \"check_out\",\n \"end\",\n ]);\nconst guestName = (b: any) =>\n b?.guest?.name ?? pick(b, [\"guest_name\", \"guestName\"]) ?? \"\";\nconst statusOf = (b: any) =>\n String(pick(b, [\"status\", \"state\"]) ?? \"\").toLowerCase();\nconst threadGuid = (b: any) =>\n pick(b, [\n \"thread_uid\",\n \"thread_guid\",\n \"threadGuid\",\n \"messaging_thread_guid\",\n \"conversation_guid\",\n \"guid\",\n ]);\n\nfunction extractTranscript(thread: any) {\n const msgs = thread?.messages ?? thread?.Messages ??\n 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(\n pick(m, [\"source\", \"from\", \"author\", \"sender\", \"direction\"]) ?? \"\",\n ).toLowerCase();\n const host = m.is_host ?? m.isHost ?? src.includes(\"host\") ??\n src.includes(\"out\");\n return (host ? \"Hôte\" : \"Voyageur\") + \": \" +\n 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 confirmée par l\\'hôte pour le linge pris. 0 si aucun. null seulement si option manifestement prise mais montant illisible.',\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));\n\nasync function callGroq(transcript: string) {\n for (let attempt = 0; attempt < 4; attempt++) {\n const res = await fetch(\"https://api.groq.com/openai/v1/chat/completions\", {\n method: \"POST\",\n headers: {\n authorization: \"Bearer \" + GROQ,\n \"content-type\": \"application/json\",\n },\n body: JSON.stringify({\n model: MODEL,\n temperature: 0,\n response_format: { type: \"json_object\" },\n messages: [{ role: \"system\", content: SYSTEM }, {\n role: \"user\",\n content: \"Conversation :\\n\\n\" + transcript,\n }],\n }),\n });\n if (res.status === 429 || res.status === 503) {\n await sleep(3000 * (attempt + 1));\n continue;\n }\n if (!res.ok) {\n throw new Error(\n \"Groq \" + res.status + \" : \" + (await res.text()).slice(0, 160),\n );\n }\n const data = await res.json();\n return data?.choices?.[0]?.message?.content || \"\";\n }\n throw new Error(\"Groq 429 (limite de vitesse) après plusieurs essais\");\n}\n\nasync function callGemini(transcript: string) {\n const url = \"https://generativelanguage.googleapis.com/v1beta/models/\" +\n MODEL + \":generateContent?key=\" + GEMINI;\n for (let attempt = 0; attempt < 4; attempt++) {\n const res = await fetch(url, {\n method: \"POST\",\n headers: { \"content-type\": \"application/json\" },\n body: JSON.stringify({\n system_instruction: { parts: [{ text: SYSTEM }] },\n contents: [{\n role: \"user\",\n parts: [{ text: \"Conversation :\\n\\n\" + transcript }],\n }],\n generationConfig: {\n temperature: 0,\n responseMimeType: \"application/json\",\n },\n }),\n });\n if (res.status === 429 || res.status === 503) {\n await sleep(4000 * (attempt + 1));\n continue;\n } // limite de vitesse : on attend puis on réessaie\n if (!res.ok) {\n throw new Error(\n \"Gemini \" + res.status + \" : \" + (await res.text()).slice(0, 160),\n );\n }\n const data = await res.json();\n return (data?.candidates?.[0]?.content?.parts || []).map((p: any) =>\n p.text || \"\"\n ).join(\"\");\n }\n throw new Error(\"Gemini 429 (limite de vitesse) après plusieurs essais\");\n}\n\nasync function classify(transcript: string) {\n const raw = PROVIDER === \"gemini\"\n ? await callGemini(transcript)\n : 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 =\n [\"complet\", \"serviettes\", \"linge_lit\", \"aucun\", \"indetermine\"].includes(\n out.categorie,\n )\n ? out.categorie\n : \"indetermine\";\n return {\n categorie: cat,\n montant_convenu: typeof out.montant_convenu === \"number\"\n ? out.montant_convenu\n : null,\n confiance: [\"haute\", \"moyenne\", \"basse\"].includes(out.confiance)\n ? out.confiance\n : \"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 [bookings, names] = await Promise.all([\n fetchAllBookings(),\n fetchPropertyNames(),\n ]);\n const kept = bookings.filter((b) => {\n const dep = departure(b);\n return dep && String(dep).slice(0, 4) === year &&\n !EXCLUDED.includes(statusOf(b));\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 const start = Date.now();\n\n for (const b of kept) {\n const id = propId(b) || \"?\";\n const name = names[id] ||\n (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 = {\n categorie: \"indetermine\",\n montant_convenu: null,\n confiance: \"basse\",\n justification: \"Pas de conversation.\",\n };\n } else if (Date.now() - start > BUDGET_MS) {\n pending++;\n continue; // pas encore lu : non compté, on reprendra au prochain chargement\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(1200); // petit délai pour rester sous la limite gratuite\n } catch (e) {\n cls = {\n categorie: \"indetermine\",\n montant_convenu: null,\n confiance: \"basse\",\n justification: \"Illisible : \" +\n String((e as Error).message).slice(0, 60),\n };\n }\n }\n }\n\n const amount = cls.montant_convenu != null && cls.montant_convenu > 0\n ? cls.montant_convenu\n : (PRIX[cls.categorie] || 0);\n const aVerifier = cls.confiance !== \"haute\" ||\n cls.categorie === \"indetermine\" ||\n (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),\n aptName: name,\n guest: guestName(b),\n amount,\n categorie: cls.categorie,\n categorieLabel: LABELS[cls.categorie],\n aVerifier,\n justification: cls.justification,\n });\n }\n\n list.sort((a, b) => b.date.localeCompare(a.date));\n return {\n year,\n total,\n pending,\n read,\n totalKept: kept.length,\n perApt: Object.values(perAptMap).sort((a: any, b: any) =>\n b.total - a.total\n ),\n monthly,\n count: list.filter((e) => e.amount > 0).length,\n aVerifier: list.filter((e) => e.aVerifier).length,\n list,\n 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 · v10