'+x[0]+'

'+x[2]+'

'+x[1]+'

').join('');const items=[...urg.slice(0,4).map(x=>({kind:'urgent',title:x.objet||x.description||'Demande urgente',sub:clientName(x),time:dt(x.created_at)})),...overdue.slice(0,3).map(x=>({kind:'warn',title:'Facture '+(x.numero||'')+' en retard',sub:clientName(x)+' · '+money(x.total_ttc),time:dateOnly(x.date_echeance)})),...tasks.filter(x=>!/(termine|done|annule)/i.test(x.statut||'')).slice(0,3).map(x=>({kind:'warn',title:x.titre||'Tâche',sub:x.priorite||'',time:dt(x.due_at||x.created_at)}))];q('#priorityList').innerHTML=items.length?items.map(x=>'

'+esc(x.title)+'

'+esc(x.sub)+'

'+esc(x.time)+'

').join(''):'

Aucune priorité critique

La file du jour est maîtrisée.

';const upcoming=appointments.filter(x=>new Date(x.date_heure||0)>=new Date()).sort((a,b)=>new Date(a.date_heure)-new Date(b.date_heure)).slice(0,5);q('#upcomingList').innerHTML=upcoming.length?upcoming.map(x=>'

'+esc(clientName(x))+'

'+esc(x.type_rdv||x.objet||'Intervention')+' · '+esc(x.adresse||'Adresse à confirmer')+'

'+dt(x.date_heure)+'

').join(''):'

Aucun rendez-vous à venir

'}\nfunction renderRequests(){const term=(q('#requestSearch')?.value||'').toLowerCase(),filter=q('#requestFilter')?.value||'all';const rows=requests.filter(x=>{const hay=JSON.stringify([x.numero,x.objet,x.description,clientName(x)]).toLowerCase();return(!term||hay.includes(term))&&(filter==='all'||(filter==='urgent'?urgent(x):String(x.statut||'')===filter))});q('#requestsBody').innerHTML=rows.length?rows.map(x=>''+esc(x.objet||'Demande')+'

'+esc(clientName(x))+'

'+pill(x.urgence||'normale')+''+pill(x.statut||'nouveau')+''+esc(x.description||'—')+''+dt(x.created_at)+'').join(''):'Aucune demande';q('#requestsMobile').innerHTML=rows.map(x=>'

'+esc(x.objet||'Demande')+'

'+esc(clientName(x))+' · '+dt(x.created_at)+'

'+pill(x.statut||'nouveau')+'

').join('')||'

Aucune demande

';q('#requestCount').textContent=rows.length}\nq('#requestSearch').oninput=renderRequests;q('#requestFilter').onchange=renderRequests;\nfunction renderAgenda(){const rows=[...appointments].sort((a,b)=>new Date(a.date_heure||0)-new Date(b.date_heure||0));q('#agendaList').innerHTML=rows.length?rows.map(x=>'

'+esc(clientName(x))+'

'+esc(x.type_rdv||x.objet||'Intervention')+' · '+esc(x.adresse||'Adresse non renseignée')+'

'+dt(x.date_heure)+'
'+pill(x.statut||'planifie')+'

').join(''):'

Aucun rendez-vous

'}\nfunction renderClients(){q('#clientsBody').innerHTML=clients.length?clients.map(x=>''+esc(x.nom||'Sans nom')+'

'+esc(x.ville||'')+'

'+esc(x.telephone||'—')+''+esc(x.email||'—')+''+pill(x.vip?'VIP':'actif')+'').join(''):'Aucun client';q('#clientsMobile').innerHTML=clients.map(x=>'

'+esc(x.nom||x.telephone||'Client')+'

'+esc([x.telephone,x.email].filter(Boolean).join(' · '))+'

').join('')||'

Aucun client

';q('#clientCount').textContent=clients.length}\nlet documentTab='quotes';function quoteRows(){return quotes.map(x=>''+esc(x.numero||'Brouillon')+'

'+esc(clientName(x))+' · '+esc(x.objet||'Sans objet')+'

'+dateOnly(x.date_emission||x.created_at)+''+money(x.total_ttc)+'

'+esc(x.lignes_count||0)+' ligne(s)

'+pill(x.statut||'brouillon')+'

'+(String(x.statut)==='brouillon'?'':'')+(!invoices.some(f=>f.devis_id===x.id)&&!/(refuse|expire)/i.test(x.statut||'')?'':'')+'

').join('')}\nfunction invoiceRows(){return invoices.map(x=>''+esc(x.numero||'Brouillon')+'

'+esc(clientName(x))+' · '+esc(textStatus(x.type_facture||'simple'))+'

'+dateOnly(x.date_emission||x.created_at)+''+money(x.total_ttc)+'

Échéance '+dateOnly(x.date_echeance)+'

'+pill(x.statut||'brouillon')+'

'+(!isPaid(x)&&!isCancelled(x)?'':'')+'

').join('')}\nfunction purchaseRows(){return purchases.map(x=>''+esc(x.numero_facture||x.fournisseur||'Achat')+'

'+esc(x.fournisseur||'Fournisseur')+'

'+dateOnly(x.date_facture||x.created_at)+''+money(x.total_ttc)+''+pill(x.ocr_statut||'en_attente')+'').join('')}\nfunction renderDocuments(){qa('[data-document-tab]').forEach(x=>x.classList.toggle('active',x.dataset.documentTab===documentTab));const body=documentTab==='quotes'?quoteRows():documentTab==='invoices'?invoiceRows():purchaseRows();q('#documentsBody').innerHTML=body||'Aucun document';bindDocumentActions()}\nqa('[data-document-tab]').forEach(x=>x.onclick=()=>{documentTab=x.dataset.documentTab;renderDocuments()});\nfunction bindDocumentActions(){qa('[data-doc-quote]').forEach(x=>x.onclick=()=>openDoc('quote',x.dataset.docQuote));qa('[data-doc-invoice]').forEach(x=>x.onclick=()=>openDoc('invoice',x.dataset.docInvoice));qa('[data-quote-ready]').forEach(x=>x.onclick=async()=>{x.disabled=true;try{await action('quote.status',{id:x.dataset.quoteReady,statut:'pret'})}catch(e){toast(e.message,false);x.disabled=false}});qa('[data-invoice-from]').forEach(x=>x.onclick=()=>openInvoiceDialog(x.dataset.invoiceFrom));qa('[data-mark-paid]').forEach(x=>x.onclick=()=>openPaymentDialog(x.dataset.markPaid))}\n\nfunction renderPilot(){\n const paid=invoices.filter(isPaid);\n const open=invoices.filter(x=>!isPaid(x)&&!isCancelled(x));\n const overdue=open.filter(x=>x.date_echeance&&new Date(x.date_echeance)x.devis_id).filter(Boolean));\n const accepted=quotes.filter(x=>/accepte/i.test(x.statut||''));\n const toInvoice=accepted.filter(x=>!invoicedQuoteIds.has(x.id));\n const followups=quotes.filter(x=>/envoye/i.test(x.statut||'')&&daysAgo(x.date_envoi||x.updated_at)>=7);\n const calls=list(ai.recent_calls).filter(x=>Number(x.risk_score)>=60);\n const received=paid.reduce((sum,x)=>sum+Number(x.total_ttc||0),0);\n const due=open.reduce((sum,x)=>sum+Number(x.total_ttc||0),0);\n const late=overdue.reduce((sum,x)=>sum+Number(x.total_ttc||0),0);\n const rate=quotes.length?Math.round(accepted.length/quotes.length*100):0;\n const cards=[['Encaissé',money(received),'Factures réglées','accent'],['À encaisser',money(due),open.length+' facture(s)','warn'],['En retard',money(late),overdue.length+' échéance(s)','bad'],['Conversion',rate+' %',accepted.length+' devis accepté(s)','']];\n q('#pilotKpis').innerHTML=cards.map(x=>'

'+x[0]+'

'+x[2]+'

'+x[1]+'

').join('');\n const insightData=[['Devis à facturer',toInvoice.length],['Relances utiles',followups.length],['Appels à reprendre',calls.length]];\n q('#pilotInsights').innerHTML=insightData.map(x=>'

'+x[0]+''+x[1]+'

').join('');\n const queue=[];\n overdue.slice(0,5).forEach(x=>queue.push({kind:'urgent',title:'Encaisser '+(x.numero||'facture'),sub:clientName(x)+' · '+money(x.total_ttc),button:'Encaisser',action:'pay',id:x.id}));\n toInvoice.slice(0,5).forEach(x=>queue.push({kind:'ok',title:'Facturer '+(x.numero||'devis'),sub:clientName(x)+' · '+money(x.total_ttc),button:'Créer facture',action:'invoice',id:x.id}));\n followups.slice(0,4).forEach(x=>queue.push({kind:'warn',title:'Relancer '+(x.numero||'devis'),sub:clientName(x)+' · envoyé il y a '+daysAgo(x.date_envoi||x.updated_at)+' jours',button:'Créer tâche',action:'task',client_id:x.client_id}));\n calls.slice(0,3).forEach(x=>queue.push({kind:'urgent',title:'Reprendre un appel',sub:(x.intent||'Appel')+' · priorité élevée',button:'Créer rappel',action:'task'}));\n q('#actionCenter').innerHTML=queue.length?queue.map((x,i)=>'

'+esc(x.title)+'

'+esc(x.sub)+'

').join(''):'

Aucune action commerciale urgente.

';\n qa('[data-queue]').forEach(button=>button.onclick=async()=>{\n const item=queue[Number(button.dataset.queue)];\n if(item.action==='pay')return openPaymentDialog(item.id);\n if(item.action==='invoice')return openInvoiceDialog(item.id);\n button.disabled=true;\n try{await action('task.create',{type_tache:'rappeler',priorite:item.kind==='urgent'?'haute':'normale',titre:item.title,description:item.sub,client_id:item.client_id||null})}catch(error){toast(error.message,false);button.disabled=false}\n });\n}\nfunction renderSettings(){const rows=[['Nom',company.nom],['Téléphone',company.tel],['E-mail',company.email],['SIRET',company.siret],['Adresse',company.adresse],['IBAN',company.iban],['Zone',settings.zone_intervention],['Rayon',settings.rayon_km?settings.rayon_km+' km':null],['TVA par défaut',settings.tva_taux_defaut?settings.tva_taux_defaut+' %':null],['Acompte par défaut',settings.acompte_pct_defaut?settings.acompte_pct_defaut+' %':null]];q('#settingsDefinition').innerHTML=rows.map(x=>'

'+x[0]+'

'+esc(x[1]||'Non renseigné')+'

').join('');const missing=configMissing();q('#blockerList').innerHTML=missing.length?missing.map(x=>'

Compléter '+esc(x)+'

').join(''):'

Identité entreprise complète

'}\n\nconst dialog=q('#actionDialog'),dialogTitle=q('#dialogTitle'),dialogBody=q('#dialogBody');function closeDialog(){dialog.close()}\nfunction openSimple(kind){const forms={request:{title:'Nouvelle demande',action:'client.create',html:'

Nom

Téléphone *

E-mail

Urgence

Demande *

'},availability:{title:'Chercher un créneau',action:'availability.check',html:'

Date souhaitée *

Durée

Adresse

'},appointment:{title:'Planifier un rendez-vous',action:'rdv.create',html:'

Téléphone client *

Date et heure *

Type

Adresse

Le client a explicitement confirmé ce créneau.

'}};const cfg=forms[kind];if(!cfg)return;dialogTitle.textContent=cfg.title;dialogBody.innerHTML='';q('[data-close]',dialogBody).onclick=closeDialog;q('#actionForm').onsubmit=async e=>{e.preventDefault();const button=q('[type=submit]',e.currentTarget),payload=Object.fromEntries(new FormData(e.currentTarget).entries());payload.explicit_confirmation=payload.explicit_confirmation==='on';button.disabled=true;try{const result=await action(cfg.action,payload,!['availability.check'].includes(cfg.action));if(cfg.action==='availability.check'){const box=q('#actionResult');box.textContent=result.message||JSON.stringify(result,null,2);box.classList.add('show')}}catch(err){toast(err.message,false);button.disabled=false}};dialog.showModal()}\nfunction quoteLine(prefill={}){const row=document.createElement('div');row.className='quote-line';row.innerHTML='';q('button',row).onclick=()=>{row.remove();updateQuoteTotals()};qa('input,select',row).forEach(x=>x.oninput=updateQuoteTotals);q('[name=designation]',row).onchange=()=>{const match=catalog.find(c=>c.designation===q('[name=designation]',row).value);if(match){q('[name=prix_unitaire_ht]',row).value=match.prix_ht||0;q('[name=tva_taux]',row).value=String(match.tva_taux||20);q('[name=unite]',row).value=match.unite||'u';updateQuoteTotals()}};q('#quoteLines').appendChild(row);updateQuoteTotals()}\nfunction updateQuoteTotals(){const lines=qa('.quote-line',dialogBody);let ht=0,tva=0;for(const row of lines){const total=Number(q('[name=quantite]',row).value||0)*Number(q('[name=prix_unitaire_ht]',row).value||0),rate=Number(q('[name=tva_taux]',row).value||0);ht+=total;tva+=total*rate/100}q('#quoteHt').textContent=money(ht);q('#quoteTva').textContent=money(tva);q('#quoteTtc').textContent=money(ht+tva)}\nfunction openQuoteDialog(){dialogTitle.textContent='Créer un devis';dialogBody.innerHTML='';q('[data-close]',dialogBody).onclick=closeDialog;q('#addQuoteLine').onclick=()=>quoteLine();quoteLine();q('#quoteForm').onsubmit=async e=>{e.preventDefault();const button=q('[type=submit]',e.currentTarget),payload=Object.fromEntries(new FormData(e.currentTarget).entries());payload.lines=qa('.quote-line',e.currentTarget).map(row=>({type_ligne:q('[name=type_ligne]',row).value,designation:q('[name=designation]',row).value,quantite:Number(q('[name=quantite]',row).value||1),unite:q('[name=unite]',row).value,prix_unitaire_ht:Number(q('[name=prix_unitaire_ht]',row).value||0),tva_taux:Number(q('[name=tva_taux]',row).value||20)}));button.disabled=true;try{const result=await action('quote.create',payload,false);dialog.close();if(result.devis?.id)openDoc('quote',result.devis.id);setTimeout(()=>location.reload(),900)}catch(err){toast(err.message,false);button.disabled=false}};dialog.showModal()}\nfunction openInvoiceDialog(devisId){const quote=quotes.find(x=>x.id===devisId)||{};dialogTitle.textContent='Créer une facture';dialogBody.innerHTML='';q('[data-close]',dialogBody).onclick=closeDialog;q('#invoiceForm').onsubmit=async e=>{e.preventDefault();const button=q('[type=submit]',e.currentTarget),payload=Object.fromEntries(new FormData(e.currentTarget).entries());payload.devis_id=devisId;button.disabled=true;try{const result=await action('invoice.from_quote',payload,false);dialog.close();if(result.facture?.id)openDoc('invoice',result.facture.id);setTimeout(()=>location.reload(),900)}catch(err){toast(err.message,false);button.disabled=false}};dialog.showModal()}\nfunction openPaymentDialog(id){if(!window.confirm('Confirmer cette facture comme réglée aujourd’hui par virement ?'))return;action('invoice.mark_paid',{id,date_paiement:todayIso(),mode_paiement:'virement'}).catch(error=>toast(error.message,false))}\nqa('[data-open-simple]').forEach(x=>x.onclick=()=>openSimple(x.dataset.openSimple));qa('[data-open-quote]').forEach(x=>x.onclick=openQuoteDialog);q('#dialogClose').onclick=closeDialog;\nconst searchDialog=q('#searchDialog'),searchInput=q('#globalSearch'),searchResults=q('#searchResults');\nfunction openSearch(){searchDialog.showModal();searchInput.value='';searchInput.focus();renderSearch('')}\nfunction renderSearch(term){term=term.toLowerCase().trim();const source=[...requests.map(x=>({view:'requests',title:x.objet||'Demande',sub:clientName(x)+' · '+textStatus(x.statut)})),...clients.map(x=>({view:'clients',title:x.nom||x.telephone||'Client',sub:[x.telephone,x.email].filter(Boolean).join(' · ')})),...quotes.map(x=>({view:'documents',title:x.numero||x.objet||'Devis',sub:clientName(x)+' · '+money(x.total_ttc)})),...invoices.map(x=>({view:'documents',title:x.numero||'Facture',sub:clientName(x)+' · '+money(x.total_ttc)}))].filter(x=>!term||(x.title+' '+x.sub).toLowerCase().includes(term)).slice(0,20);searchResults.innerHTML=source.length?source.map((x,i)=>'').join(''):'

Aucun résultat

';qa('[data-result]',searchResults).forEach(x=>x.onclick=()=>{showView(source[Number(x.dataset.result)].view);searchDialog.close()})}\nq('#searchTrigger').onclick=openSearch;searchInput.oninput=()=>renderSearch(searchInput.value);q('#searchClose').onclick=()=>searchDialog.close();document.addEventListener('keydown',event=>{if((event.ctrlKey||event.metaKey)&&event.key.toLowerCase()==='k'){event.preventDefault();openSearch()}if(event.key==='Escape'){searchDialog.close();dialog.close()}});\nq('#logout').onclick=async()=>{await fetch('/logout',{method:'POST',headers:{'x-csrf-token':csrf}});location.href='/'};\nq('#goDocuments').onclick=()=>showView('documents');\nasync function loadOperationsStatus(){const el=q('#systemState');if(!el)return;try{const response=await fetch('/api/operations-status');const status=await response.json();el.className='system-state '+(status.mode||'');el.textContent=status.pending_actions>0?status.label+' · '+status.pending_actions+' en attente':status.label;el.title=status.explanation||''}catch{el.className='system-state limited';el.textContent='État indisponible'}}\nvoid loadOperationsStatus();\nq('#todayDate').textContent=new Intl.DateTimeFormat('fr-FR',{weekday:'long',day:'numeric',month:'long'}).format(new Date());renderToday();renderRequests();renderAgenda();renderClients();renderDocuments();renderPilot();renderSettings();showView(location.hash.slice(1)||'today');\n`;\nfunction safeJson(value: unknown): string {\n return JSON.stringify(value).replace(/ {\n return {\n \"Content-Type\": contentType,\n \"Access-Control-Allow-Origin\": \"https://idleyer--66ce4ade7caf11f189831607ee4eb77e.web.val.run\",\n \"Access-Control-Allow-Methods\": \"GET, POST\",\n \"Access-Control-Allow-Headers\": \"Content-Type, X-CSRF-Token, X-Owner-Access-Token\",\n \"Vary\": \"Origin\",\n \"Cache-Control\": \"no-store, max-age=0\",\n \"Pragma\": \"no-cache\",\n \"Strict-Transport-Security\": \"max-age=31536000; includeSubDomains\",\n \"X-Permitted-Cross-Domain-Policies\": \"none\",\n \"Origin-Agent-Cluster\": \"?1\",\n \"Content-Security-Policy\": `default-src 'self'; style-src 'nonce-${nonce}'; script-src 'nonce-${nonce}'; img-src 'self' data:; connect-src 'self'; font-src 'self'; frame-ancestors 'none'; base-uri 'self'; form-action 'self'; object-src 'none'`,\n \"X-Frame-Options\": \"DENY\",\n \"X-Content-Type-Options\": \"nosniff\",\n \"Referrer-Policy\": \"no-referrer\",\n \"Permissions-Policy\": \"camera=(), microphone=(self), geolocation=(), payment=(), usb=()\",\n \"Cross-Origin-Opener-Policy\": \"same-origin\",\n \"Cross-Origin-Resource-Policy\": \"same-origin\",\n };\n}\n\nexport function loginPage(error: string, nonce: string): string {\n return `Connexion · Secrétariat`;\n}\n\nexport function appPage(data: Record, session: Session, nonce: string): string {\n return `Secrétariat PiscinisteAller au contenu

À traiter maintenant

Priorités commerciales et interventions du jour.

Priorités

Actions rapides

Prochains rendez-vous

File opérationnelle

Demandes

Demande	Priorité	Statut	Objet	Créée

Planning

Agenda

Portefeuille

Clients

0 clients

Client	Téléphone	E-mail	État

Vente et comptabilité

Documents

Créer, facturer, imprimer et encaisser.

Document	Date	Montant	Statut

Décisions utiles

Pilotage

Ce qui doit être encaissé, facturé ou relancé.

Centre d’actions

Actions réellement exécutables

Accès directs

Commandes et décisions

Assistante personnelle

Consultez l’activité en direct, sans exécution n8n, et préparez les actions sensibles à valider.

Chargement

Console dirigeantVérification…Lecture directe sécurisée

Passerelle métierVérification…Supabase audité · sans n8n

Identité dirigeantVérification…Forte identité requise pour écrire

Agent vocalVérification…OpenAI Realtime

Sécurité du dirigeant

Connexion e-mail sans mot de passe

Vérification de la session propriétaire…

\n Compte propriétaire sécurisé\n

\n Vérification\n \n \n

Centre d’activation

État réel des prérequis. Cette lecture ne consomme aucune exécution n8n et n’active aucun envoi.

Chargement…Vérification

Diagnostic en coursLecture des garde-fous…

Patientez

Prochaines actions

1Chargement du plan d’activation…

◉

Parler à la secrétaire IA

La console de lecture est directe. Les écritures restent en aperçu et la voix demeure verrouillée tant que l’identité forte n’est pas liée.

Commandes rapides

Accès direct sécurisé

\n \n \n \n \n \n \n \n

Aucune commande lancée.

Garde-fous avant activation

Vérification en cours…

Validations en attente

—

Chargez l’état de l’autonomie.

Automatisations candidates

—

Aucune analyse chargée.

Politique de communication

Connexion calendrier

Suivi de livraison Twilio

Lecture seule · aucun renvoi automatique

En attente—

Envoyés—

Livrés—

Échecs—

Confidentialité : le cockpit n’affiche ni numéro de téléphone ni contenu de SMS, seulement un suffixe technique et l’état de livraison.

Derniers SMS suivis

Chargez « Livraison des SMS ».

Alertes de livraison

—

Aucune donnée chargée.

Premier SMS technique

Bloqué en sécurité

Chargez le suivi pour voir les contrôles.

Aucun SMS ne peut partir depuis ce bloc.

Identité et conditions

Réglages

À compléter

\n \n \n

\n `;\n}\n",[],[448,514],"2aaf79ec-f15e-4132-8004-f19779687610","twilio-status.ts","019f66f6-e506-776c-9df7-8c40b84b4b39",["D",1784138884418],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { reserveN8nExecution } from \"./n8n-budget.ts\";\n\nfunction env(key: string): string {\n try {\n return Deno.env.has(key) ? (Deno.env.get(key) || \"\") : \"\";\n } catch {\n return \"\";\n }\n}\n\nconst N8N_BASE = env(\"PISCINE_N8N_BASE\").replace(/\\/$/, \"\");\nconst STATUS_PATH = env(\"PISCINE_TWILIO_STATUS_N8N_PATH\").replace(/^\\//, \"\");\nconst TOOL_SECRET = env(\"PISCINE_TOOL_SECRET\");\nconst TENANT = env(\"PISCINE_TENANT\") || \"pisciniste_01\";\nconst TWILIO_AUTH_TOKEN = env(\"PISCINE_TWILIO_AUTH_TOKEN\");\nconst LEGACY_STATUS_GATEWAY_PUBLISHED =\n env(\"PISCINE_TWILIO_STATUS_GATEWAY_PUBLISHED\") === \"true\";\nconst RECEIVER_ENABLED =\n env(\"PISCINE_TWILIO_STATUS_RECEIVER_ENABLED\") === \"true\";\nconst STATUS_GATEWAY_PUBLISHED =\n LEGACY_STATUS_GATEWAY_PUBLISHED || RECEIVER_ENABLED;\n\nexport type NormalizedTwilioStatus = {\n provider_status: string;\n delivery_state:\n | \"queued\"\n | \"provider_accepted\"\n | \"sent\"\n | \"delivered\"\n | \"opened\"\n | \"failed\"\n | \"undelivered\";\n terminal: boolean;\n};\n\nexport function normalizeTwilioStatus(\n value: unknown,\n): NormalizedTwilioStatus | null {\n const provider_status = String(value ?? \"\").trim().toLowerCase();\n if (provider_status === \"queued\" || provider_status === \"scheduled\") {\n return { provider_status, delivery_state: \"queued\", terminal: false };\n }\n if (provider_status === \"accepted\" || provider_status === \"sending\") {\n return {\n provider_status,\n delivery_state: \"provider_accepted\",\n terminal: false,\n };\n }\n if (provider_status === \"sent\") {\n return { provider_status, delivery_state: \"sent\", terminal: false };\n }\n if (provider_status === \"delivered\" || provider_status === \"received\") {\n return { provider_status, delivery_state: \"delivered\", terminal: true };\n }\n if (provider_status === \"read\") {\n return { provider_status, delivery_state: \"opened\", terminal: true };\n }\n if (provider_status === \"undelivered\") {\n return { provider_status, delivery_state: \"undelivered\", terminal: true };\n }\n if (provider_status === \"failed\" || provider_status === \"canceled\") {\n return { provider_status, delivery_state: \"failed\", terminal: true };\n }\n return null;\n}\n\nfunction canonicalForm(\n exactUrl: string,\n params: URLSearchParams,\n): string {\n const entries = [...params.entries()].sort(([leftKey, leftValue], [rightKey, rightValue]) => {\n const keyOrder = leftKey.localeCompare(rightKey);\n return keyOrder || leftValue.localeCompare(rightValue);\n });\n return exactUrl + entries.map(([key, value]) => key + value).join(\"\");\n}\n\nfunction bytesToBase64(bytes: Uint8Array): string {\n let binary = \"\";\n for (const byte of bytes) binary += String.fromCharCode(byte);\n return btoa(binary);\n}\n\nexport async function computeTwilioFormSignature(\n exactUrl: string,\n params: URLSearchParams,\n authToken: string,\n): Promise {\n if (!authToken) return \"\";\n const key = await crypto.subtle.importKey(\n \"raw\",\n new TextEncoder().encode(authToken),\n { name: \"HMAC\", hash: \"SHA-1\" },\n false,\n [\"sign\"],\n );\n const digest = await crypto.subtle.sign(\n \"HMAC\",\n key,\n new TextEncoder().encode(canonicalForm(exactUrl, params)),\n );\n return bytesToBase64(new Uint8Array(digest));\n}\n\nfunction constantTimeEqual(left: string, right: string): boolean {\n const max = Math.max(left.length, right.length);\n let difference = left.length ^ right.length;\n for (let index = 0; index < max; index += 1) {\n difference |= (left.charCodeAt(index) || 0) ^ (right.charCodeAt(index) || 0);\n }\n return difference === 0;\n}\n\nexport async function validateTwilioFormSignature(\n exactUrl: string,\n params: URLSearchParams,\n suppliedSignature: string,\n authToken = TWILIO_AUTH_TOKEN,\n): Promise {\n if (!authToken || !suppliedSignature) return false;\n const expected = await computeTwilioFormSignature(exactUrl, params, authToken);\n return constantTimeEqual(expected, suppliedSignature.trim());\n}\n\nexport async function configuredTwilioAuthTokenSelfTest(): Promise<{\n ok: boolean;\n tamper_rejected: boolean;\n}> {\n if (!TWILIO_AUTH_TOKEN) return { ok: false, tamper_rejected: false };\n\n const exactUrl = \"https://self-test.invalid/twilio-status\";\n const params = new URLSearchParams({\n MessageSid: \"SM11111111111111111111111111111111\",\n MessageStatus: \"delivered\",\n });\n const signature = await computeTwilioFormSignature(\n exactUrl,\n params,\n TWILIO_AUTH_TOKEN,\n );\n const valid = await validateTwilioFormSignature(\n exactUrl,\n params,\n signature,\n );\n params.set(\"MessageStatus\", \"failed\");\n const tampered = await validateTwilioFormSignature(\n exactUrl,\n params,\n signature,\n );\n return { ok: valid && !tampered, tamper_rejected: !tampered };\n}\n\nfunction clean(value: unknown, max: number): string {\n return String(value ?? \"\").trim().slice(0, max);\n}\n\nexport function buildSanitizedTwilioStatusPayload(\n params: URLSearchParams,\n occurredAt = new Date().toISOString(),\n context: Record = {},\n): Record | null {\n const messageSid = clean(params.get(\"MessageSid\"), 64);\n const normalized = normalizeTwilioStatus(params.get(\"MessageStatus\"));\n if (!/^(SM|MM)[0-9A-Za-z]{32}$/.test(messageSid) || !normalized) return null;\n\n const documentType = clean(context.document_type, 16).toLowerCase();\n const documentId = clean(context.document_id, 64);\n const documentLinked =\n (documentType === \"quote\" || documentType === \"invoice\") &&\n /^[0-9a-f]{8}-[0-9a-f]{4}-[1-5][0-9a-f]{3}-[89ab][0-9a-f]{3}-[0-9a-f]{12}$/i\n .test(documentId);\n\n return {\n schema_version: \"1.0\",\n tenant_id: TENANT,\n source: \"valtown-twilio-status\",\n message_sid: messageSid,\n message_status: normalized.provider_status,\n delivery_state: normalized.delivery_state,\n terminal: normalized.terminal,\n document_type: documentLinked ? documentType : null,\n document_id: documentLinked ? documentId : null,\n self_test:\n messageSid === \"SM22222222222222222222222222222222\" &&\n params.get(\"PiscineSelfTest\") === \"1\",\n error_code: clean(params.get(\"ErrorCode\"), 64) || null,\n error_message: clean(params.get(\"ErrorMessage\"), 500) || null,\n occurred_at: occurredAt,\n raw_status: {\n ChannelPrefix: clean(params.get(\"ChannelPrefix\"), 32) || null,\n EventType: clean(params.get(\"EventType\"), 64) || null,\n },\n };\n}\n\nconst STATUS_QUEUE_SCHEMA = `\n create table if not exists twilio_status_fallback_queue (\n event_key text primary key,\n payload_json text not null,\n forward_state text not null default 'pending',\n attempts integer not null default 0,\n last_error text,\n created_at text not null,\n updated_at text not null,\n forwarded_at text\n )\n`;\n\nasync function ensureTwilioStatusQueue() {\n await sqlite.execute(STATUS_QUEUE_SCHEMA);\n}\n\nfunction twilioStatusEventKey(payload: Record): string {\n const tenant = clean(payload.tenant_id, 80);\n const messageSid = clean(payload.message_sid, 64);\n const deliveryState = clean(payload.delivery_state, 32);\n if (!tenant || !/^(SM|MM)[0-9A-Za-z]{32}$/.test(messageSid) || !deliveryState) {\n throw new Error(\"invalid_twilio_status_queue_key\");\n }\n return [tenant, \"twilio\", messageSid, deliveryState].join(\":\");\n}\n\nexport async function persistTwilioStatusFallback(\n payload: Record,\n reason = \"n8n_forward_pending\",\n): Promise<{ event_key: string; queue_depth: number }> {\n await ensureTwilioStatusQueue();\n const eventKey = twilioStatusEventKey(payload);\n await sqlite.execute({\n sql: `insert into twilio_status_fallback_queue (\n event_key,payload_json,forward_state,attempts,last_error,created_at,updated_at\n ) values (\n :event_key,:payload_json,'pending',0,:last_error,datetime('now'),datetime('now')\n )\n on conflict(event_key) do update set\n payload_json=excluded.payload_json,\n forward_state=case\n when twilio_status_fallback_queue.forward_state='forwarded' then 'forwarded'\n else 'pending'\n end,\n last_error=case\n when twilio_status_fallback_queue.forward_state='forwarded' then twilio_status_fallback_queue.last_error\n else excluded.last_error\n end,\n updated_at=datetime('now')`,\n args: {\n event_key: eventKey,\n payload_json: JSON.stringify(payload),\n last_error: clean(reason, 160) || \"n8n_forward_pending\",\n },\n });\n const depthResult = await sqlite.execute(\n \"select count(*) as queue_depth from twilio_status_fallback_queue where forward_state='pending'\",\n );\n const row = depthResult.rows[0] as Record | undefined;\n return { event_key: eventKey, queue_depth: Number(row?.queue_depth || 0) };\n}\n\nexport async function markTwilioStatusForwarded(eventKey: string) {\n await ensureTwilioStatusQueue();\n await sqlite.execute({\n sql: `update twilio_status_fallback_queue\n set forward_state='forwarded',\n last_error=null,\n forwarded_at=datetime('now'),\n updated_at=datetime('now')\n where event_key=:event_key`,\n args: { event_key: clean(eventKey, 240) },\n });\n}\n\nexport async function markTwilioStatusForwardFailed(\n eventKey: string,\n reason: string,\n) {\n await ensureTwilioStatusQueue();\n await sqlite.execute({\n sql: `update twilio_status_fallback_queue\n set forward_state='pending',\n attempts=attempts+1,\n last_error=:last_error,\n updated_at=datetime('now')\n where event_key=:event_key and forward_state<>'forwarded'`,\n args: {\n event_key: clean(eventKey, 240),\n last_error: clean(reason, 160) || \"n8n_forward_failed\",\n },\n });\n}\n\nexport async function twilioStatusQueueHealth() {\n await ensureTwilioStatusQueue();\n const result = await sqlite.execute(`\n select\n count(*) filter (where forward_state='pending') as pending,\n count(*) filter (where forward_state='forwarded') as forwarded,\n coalesce(max(attempts),0) as max_attempts\n from twilio_status_fallback_queue\n `);\n const row = result.rows[0] as Record | undefined;\n return {\n durable_fallback: true,\n pending: Number(row?.pending || 0),\n forwarded: Number(row?.forwarded || 0),\n max_attempts: Number(row?.max_attempts || 0),\n };\n}\n\nexport async function replayQueuedTwilioStatuses(limit = 50) {\n await ensureTwilioStatusQueue();\n const safeLimit = Math.max(1, Math.min(50, Number(limit) || 50));\n const queued = await sqlite.execute({\n sql: `select event_key,payload_json,attempts\n from twilio_status_fallback_queue\n where forward_state='pending'\n order by created_at\n limit :limit`,\n args: { limit: safeLimit },\n });\n\n const events: Array> = [];\n for (const raw of queued.rows as Array>) {\n try {\n const parsed = JSON.parse(String(raw.payload_json || \"{}\"));\n if (parsed && typeof parsed === \"object\" && !Array.isArray(parsed)) {\n events.push({\n ...(parsed as Record),\n event_key: clean(raw.event_key, 240),\n });\n }\n } catch {\n await markTwilioStatusForwardFailed(\n clean(raw.event_key, 240),\n \"invalid_queued_payload\",\n );\n }\n }\n\n if (!events.length) {\n return {\n ok: true,\n inspected: queued.rows.length,\n forwarded: 0,\n failed: 0,\n n8n_executions: 0,\n batch_execution: true,\n automatic_retry: false,\n secrets_exposed: false,\n };\n }\n\n let response: { status: number; payload: Record };\n try {\n response = await forwardTwilioStatusBatch(events);\n } catch {\n response = {\n status: 503,\n payload: { ok: false, error: \"n8n_unreachable\" },\n };\n }\n\n const resultRows = Array.isArray(response.payload.results)\n ? response.payload.results as Array>\n : [];\n const resultsByKey = new Map(\n resultRows.map((item) => [clean(item.event_key, 240), item]),\n );\n let forwarded = 0;\n let failed = 0;\n for (const event of events) {\n const eventKey = clean(event.event_key, 240);\n const item = resultsByKey.get(eventKey);\n if (\n response.status >= 200 &&\n response.status < 300 &&\n item?.ok === true\n ) {\n await markTwilioStatusForwarded(eventKey);\n forwarded += 1;\n } else {\n await markTwilioStatusForwardFailed(\n eventKey,\n clean(response.payload.error || \"n8n_batch_item_failed\", 160),\n );\n failed += 1;\n }\n }\n\n return {\n ok: failed === 0,\n inspected: queued.rows.length,\n forwarded,\n failed,\n n8n_executions: 1,\n batch_execution: true,\n automatic_retry: false,\n secrets_exposed: false,\n };\n}\n\nasync function sha256Hex(value: string): Promise {\n const digest = await crypto.subtle.digest(\n \"SHA-256\",\n new TextEncoder().encode(value),\n );\n return [...new Uint8Array(digest)]\n .map((byte) => byte.toString(16).padStart(2, \"0\"))\n .join(\"\");\n}\n\nfunction canonicalForwardPayload(\n payload: Record,\n requestId: string,\n timestamp: string,\n): string {\n return [\n timestamp,\n requestId,\n clean(payload.schema_version, 16),\n clean(payload.tenant_id, 80),\n clean(payload.source, 80),\n clean(payload.message_sid, 64),\n clean(payload.message_status, 32),\n clean(payload.occurred_at, 64),\n ].join(\"|\");\n}\n\nasync function signedForwardHeaders(\n payload: Record,\n requestId: string,\n): Promise> {\n const timestamp = String(Math.floor(Date.now() / 1000));\n const keyHash = await sha256Hex(TOOL_SECRET);\n const signature = await sha256Hex(\n keyHash + \":\" + canonicalForwardPayload(payload, requestId, timestamp),\n );\n return {\n \"content-type\": \"application/json\",\n \"x-piscine-source\": \"valtown-twilio-status\",\n \"x-piscine-timestamp\": timestamp,\n \"x-piscine-signature\": signature,\n \"x-request-id\": requestId,\n };\n}\n\nfunction canonicalForwardBatch(\n body: Record,\n requestId: string,\n timestamp: string,\n): string {\n const events = Array.isArray(body.events) ? body.events : [];\n return [\n timestamp,\n requestId,\n clean(body.schema_version, 16),\n clean(body.tenant_id, 80),\n clean(body.source, 80),\n String(events.length),\n \"\",\n ].join(\"|\");\n}\n\nasync function signedForwardBatchHeaders(\n body: Record,\n requestId: string,\n): Promise> {\n const timestamp = String(Math.floor(Date.now() / 1000));\n const keyHash = await sha256Hex(TOOL_SECRET);\n const events = Array.isArray(body.events) ? body.events : [];\n const eventDigest = await sha256Hex(JSON.stringify(events));\n const canonical = canonicalForwardBatch(\n body,\n requestId,\n timestamp,\n ).replace(/\\|$/, \"|\" + eventDigest);\n const signature = await sha256Hex(keyHash + \":\" + canonical);\n return {\n \"content-type\": \"application/json\",\n \"x-piscine-source\": \"valtown-twilio-status\",\n \"x-piscine-timestamp\": timestamp,\n \"x-piscine-signature\": signature,\n \"x-request-id\": requestId,\n };\n}\n\nexport async function forwardTwilioStatusBatch(\n inputEvents: Array>,\n): Promise<{ status: number; payload: Record }> {\n const gateway = twilioStatusGatewayStatus();\n const events = inputEvents.slice(0, 50);\n if (!gateway.available || !gateway.n8n_configured || !events.length) {\n return {\n status: 503,\n payload: { ok: false, error: \"twilio_status_batch_forwarder_unavailable\" },\n };\n }\n\n const requestId = crypto.randomUUID();\n const budget = await reserveN8nExecution(\n \"callback_batch\",\n `twilio-status-batch:${requestId}`,\n { channel: \"twilio_status\", batch_size: events.length },\n );\n if (!budget.allowed) {\n return {\n status: 429,\n payload: {\n ok: false,\n error: budget.error || \"n8n_project_daily_budget_exhausted\",\n budget_blocked: true,\n },\n };\n }\n\n const body: Record = {\n schema_version: \"1.0\",\n tenant_id: TENANT,\n source: \"valtown-twilio-status-batch\",\n request_id: requestId,\n events,\n };\n const headers = await signedForwardBatchHeaders(body, requestId);\n const response = await fetch(`${N8N_BASE}/webhook/${STATUS_PATH}`, {\n method: \"POST\",\n headers,\n body: JSON.stringify(body),\n signal: AbortSignal.timeout(8000),\n });\n const raw = await response.text();\n let payload: Record;\n try {\n payload = JSON.parse(raw);\n } catch {\n payload = { ok: false, error: \"twilio_status_batch_invalid_response\" };\n }\n return { status: response.status, payload };\n}\n\nexport function twilioStatusGatewayStatus() {\n const n8n_configured = Boolean(N8N_BASE && STATUS_PATH && TOOL_SECRET);\n const auth_token_configured = Boolean(TWILIO_AUTH_TOKEN);\n return {\n published: STATUS_GATEWAY_PUBLISHED,\n activation_source: RECEIVER_ENABLED\n ? \"receiver_only_v2\"\n : LEGACY_STATUS_GATEWAY_PUBLISHED\n ? \"legacy_gate\"\n : \"none\",\n auth_token_configured,\n n8n_configured,\n available: STATUS_GATEWAY_PUBLISHED && auth_token_configured,\n durable_fallback: true,\n forwarder_configured: n8n_configured,\n forwarding_auth: \"signed_request_v2\" as const,\n forwarding_mode: \"batched\" as const,\n immediate_forward: false,\n max_batch_size: 50,\n mode: \"delivery_status_ingest_only\" as const,\n };\n}\n\nexport async function forwardTwilioStatus(\n payload: Record,\n): Promise<{ status: number; payload: Record }> {\n const gateway = twilioStatusGatewayStatus();\n if (!gateway.available || !gateway.n8n_configured) {\n return {\n status: 503,\n payload: { ok: false, error: \"twilio_status_forwarder_unavailable\" },\n };\n }\n\n const requestId = crypto.randomUUID();\n const budget = await reserveN8nExecution(\n \"production\",\n `twilio-status-single:${requestId}`,\n { channel: \"twilio_status\", legacy_single: true },\n );\n if (!budget.allowed) {\n return {\n status: 429,\n payload: {\n ok: false,\n error: budget.error || \"n8n_project_daily_budget_exhausted\",\n budget_blocked: true,\n },\n };\n }\n const headers = await signedForwardHeaders(payload, requestId);\n const response = await fetch(`${N8N_BASE}/webhook/${STATUS_PATH}`, {\n method: \"POST\",\n headers,\n body: JSON.stringify({ ...payload, request_id: requestId }),\n signal: AbortSignal.timeout(8000),\n });\n\n const body = await response.text();\n let parsed: Record;\n try {\n parsed = JSON.parse(body);\n } catch {\n parsed = { ok: false, error: \"twilio_status_ingest_invalid_response\" };\n }\n return { status: response.status, payload: parsed };\n}\n",[],[448,523],"2f5f632b-4bc7-4282-aac0-6e2cda33f388","realtime-bridge.ts","019f66f6-e506-776c-9df7-89299e67e9e6",["D",1784138884418],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport {\n openN8nCircuit,\n reserveN8nExecution,\n secondsUntilNextMonthReset,\n type N8nBudgetCategory,\n} from \"./n8n-budget.ts\";\nimport {\n claimQueuedBusinessActions,\n completeQueuedBusinessAction,\n failQueuedBusinessAction,\n isQueueableBusinessAction,\n queueBusinessAction,\n} from \"./business-queue.ts\";\n\nexport type CallContext = {\n call_id: string;\n from_number: string;\n to_number: string;\n started_at: string;\n};\n\nconst N8N_BASE = (Deno.env.get(\"PISCINE_N8N_BASE\") || \"\").replace(/\\/$/, \"\");\nconst INTERNAL_PATH = (Deno.env.get(\"PISCINE_N8N_INTERNAL_PATH\") || \"\").trim();\nconst TOOL_SECRET = Deno.env.get(\"PISCINE_TOOL_SECRET\") || \"\";\nconst TENANT = Deno.env.get(\"PISCINE_TENANT\") || \"pisciniste_01\";\nconst EVENT_PATH = Deno.env.get(\"PISCINE_OPENAI_EVENT_PATH\") || \"secretariat-pisciniste-openai-events\";\n\nfunction clean(value: unknown, max = 4000): string {\n return String(value ?? \"\").trim().slice(0, max);\n}\n\nexport function normalizePhone(value: unknown): string {\n const input = clean(value, 200);\n const match = input.match(/(?:sip:|tel:)?(\\+?[0-9]{6,15})/i);\n return (match?.[1] || \"\").replace(/[^+0-9]/g, \"\");\n}\n\nexport function bridgeConfigured(): boolean {\n return Boolean(N8N_BASE && INTERNAL_PATH && TOOL_SECRET);\n}\n\nasync function postJson(\n url: string,\n body: Record,\n timeoutMs: number,\n budgetPurpose = \"realtime\",\n budgetCategory: N8nBudgetCategory = \"production\",\n reservationKey?: string,\n): Promise> {\n const budget = await reserveN8nExecution(\n budgetCategory,\n reservationKey || `realtime:${budgetPurpose}:${crypto.randomUUID()}`,\n { channel: \"valtown_realtime\", purpose: budgetPurpose },\n );\n if (!budget.allowed) {\n return {\n ok: false,\n error: clean(budget.error || \"n8n_project_daily_budget_exhausted\", 120),\n budget_blocked: true,\n };\n }\n const controller = new AbortController();\n const timer = setTimeout(() => controller.abort(), timeoutMs);\n try {\n const response = await fetch(url, {\n method: \"POST\",\n headers: {\n \"content-type\": \"application/json\",\n \"x-piscine-source\": \"valtown-realtime\",\n \"x-piscine-tool-secret\": TOOL_SECRET,\n \"x-request-id\": crypto.randomUUID(),\n },\n body: JSON.stringify(body),\n signal: controller.signal,\n });\n const raw = (await response.text()).slice(0, 100_000);\n if (/execution limit reached|max executions|quota.*execution/i.test(raw)) {\n await openN8nCircuit(\"n8n_account_execution_limit_reached\", secondsUntilNextMonthReset());\n return {\n ok: false,\n error: \"n8n_account_execution_limit_reached\",\n budget_blocked: true,\n circuit_opened: true,\n };\n }\n let payload: Record = {};\n try {\n payload = raw ? JSON.parse(raw) : {};\n } catch {\n payload = { ok: false, error: \"invalid_upstream_json\" };\n }\n if (!response.ok) {\n return { ok: false, error: clean(payload.error || `upstream_${response.status}`, 120), status: response.status };\n }\n return payload;\n } catch (error) {\n return {\n ok: false,\n error: error instanceof DOMException && error.name === \"AbortError\" ? \"upstream_timeout\" : \"upstream_unavailable\",\n };\n } finally {\n clearTimeout(timer);\n }\n}\n\nexport async function callBusinessTool(\n action: string,\n args: Record,\n call: CallContext,\n): Promise> {\n const data = {\n ...args,\n customer_phone: clean(args.customer_phone || call.from_number, 40),\n request_id: clean(args.request_id || `${call.call_id}:${action}:${crypto.randomUUID()}`, 240),\n };\n if (!bridgeConfigured()) {\n return isQueueableBusinessAction(action)\n ? await queueBusinessAction(action, data, call.call_id, \"business_bridge_not_configured\")\n : {\n ok: false,\n action_completed: false,\n error: \"business_bridge_not_configured\",\n safe_to_announce: true,\n requires_human: true,\n assistant_message: \"Cette vérification est momentanément indisponible. L’équipe doit vous rappeler.\",\n };\n }\n const timeoutByAction: Record = {\n client_context: 3_000,\n update_client: 4_500,\n knowledge_lookup: 4_500,\n next_best_action: 4_500,\n check_availability: 5_500,\n create_lead: 6_000,\n estimate_quote: 5_500,\n create_quote: 7_000,\n book_appointment: 6_500,\n cancel_appointment: 5_500,\n save_call_summary: 4_500,\n transfer_to_human: 5_500,\n };\n const result = await postJson(`${N8N_BASE}/webhook/${INTERNAL_PATH}`, {\n args: { action, data },\n call: {\n call_id: call.call_id,\n from_number: call.from_number,\n to_number: call.to_number,\n provider: \"openai_realtime\",\n },\n }, timeoutByAction[action] || 6_000, `business_tool:${action}`);\n\n const unavailable = result.ok === false && (\n result.error === \"upstream_timeout\"\n || result.error === \"upstream_unavailable\"\n || result.error === \"n8n_circuit_open\"\n || result.error === \"n8n_account_execution_limit_reached\"\n || result.budget_blocked === true\n );\n if (unavailable && isQueueableBusinessAction(action)) {\n return queueBusinessAction(action, data, call.call_id, String(result.error || \"upstream_unavailable\"));\n }\n if (unavailable) {\n return {\n ...result,\n action_completed: false,\n safe_to_announce: true,\n requires_human: true,\n assistant_message: \"Cette vérification est momentanément indisponible. L’équipe doit vous rappeler.\",\n };\n }\n return result;\n}\n\nexport async function replayQueuedBusinessActions(limit = 20) {\n if (!bridgeConfigured()) {\n return { ok: false, replayed: 0, error: \"business_bridge_not_configured\" };\n }\n const queued = await claimQueuedBusinessActions(limit);\n if (!queued.length) return { ok: true, replayed: 0, pending: 0 };\n\n let replayed = 0;\n let failed = 0;\n for (const item of queued) {\n const result = await postJson(`${N8N_BASE}/webhook/${INTERNAL_PATH}`, {\n args: { action: item.action, data: item.payload },\n call: {\n call_id: item.call_id,\n from_number: clean(item.payload.customer_phone, 40),\n provider: \"openai_realtime_recovery\",\n },\n }, 8_000, `business_replay:${item.action}`, \"callback_batch\",\n `recovery:business:${item.queue_id}:attempt:${Number(item.attempts || 0) + 1}`);\n if (result.ok === false) {\n failed += 1;\n await failQueuedBusinessAction(item.queue_id, String(result.error || \"replay_failed\"), 86400);\n if (result.budget_blocked === true || result.error === \"n8n_circuit_open\") break;\n } else {\n replayed += 1;\n await completeQueuedBusinessAction(item.queue_id);\n }\n }\n return { ok: failed === 0, replayed, failed, inspected: queued.length };\n}\n\nconst VOICE_EVENT_BUFFER_SCHEMA = `create table if not exists voice_event_buffer (\n event_id text primary key,\n call_id text not null,\n event_type text not null,\n payload_json text not null,\n forward_state text not null default 'pending',\n attempt_count integer not null default 0,\n last_error text,\n next_attempt_at integer not null default 0,\n created_at text not null,\n forwarded_at text\n)`;\n\nlet voiceEventBufferReady: Promise | null = null;\n\nasync function ensureVoiceEventBuffer(): Promise {\n if (!voiceEventBufferReady) {\n voiceEventBufferReady = (async () => {\n await sqlite.execute(VOICE_EVENT_BUFFER_SCHEMA);\n for (const statement of [\n \"alter table voice_event_buffer add column attempt_count integer not null default 0\",\n \"alter table voice_event_buffer add column last_error text\",\n \"alter table voice_event_buffer add column next_attempt_at integer not null default 0\",\n ]) {\n try {\n await sqlite.execute(statement);\n } catch {\n // Colonne déjà présente.\n }\n }\n await sqlite.execute(\n \"create index if not exists voice_event_buffer_pending_idx on voice_event_buffer(forward_state,next_attempt_at,created_at)\",\n );\n })().catch((error) => {\n voiceEventBufferReady = null;\n throw error;\n });\n }\n await voiceEventBufferReady;\n}\n\nasync function bufferVoiceEvent(\n event: Record,\n call: CallContext,\n): Promise<{ event_id: string; pending_for_call: number; event_type: string }> {\n await ensureVoiceEventBuffer();\n const eventType = clean(event.event_type || \"unknown\", 80);\n const eventId = clean(\n event.event_id || `${call.call_id}:${eventType}:${crypto.randomUUID()}`,\n 240,\n );\n const payload = {\n tenant_id: TENANT,\n provider: \"openai_realtime\",\n call_id: call.call_id,\n from_number: call.from_number,\n to_number: call.to_number,\n started_at: call.started_at,\n ...event,\n event_id: eventId,\n };\n await sqlite.execute({\n sql: `insert or ignore into voice_event_buffer (\n event_id,call_id,event_type,payload_json,forward_state,created_at\n ) values (\n :event_id,:call_id,:event_type,:payload_json,'pending',datetime('now')\n )`,\n args: {\n event_id: eventId,\n call_id: clean(call.call_id, 240),\n event_type: eventType,\n payload_json: JSON.stringify(payload).slice(0, 100_000),\n },\n });\n const count = await sqlite.execute({\n sql: `select count(*) as pending\n from voice_event_buffer\n where call_id=:call_id and forward_state='pending'`,\n args: { call_id: clean(call.call_id, 240) },\n });\n return {\n event_id: eventId,\n event_type: eventType,\n pending_for_call: Number((count.rows[0] as Record | undefined)?.pending || 0),\n };\n}\n\nasync function markVoiceCallForwarded(callId: string) {\n await ensureVoiceEventBuffer();\n await sqlite.execute({\n sql: `update voice_event_buffer\n set forward_state='forwarded',forwarded_at=datetime('now'),last_error=null\n where call_id=:call_id and forward_state='pending'`,\n args: { call_id: clean(callId, 240) },\n });\n}\n\nexport async function voiceEventBufferStatus() {\n await ensureVoiceEventBuffer();\n const totals = await sqlite.execute(`select\n count(*) filter(where forward_state='pending') as pending_events,\n count(*) filter(where forward_state='forwarded') as forwarded_events,\n min(created_at) filter(where forward_state='pending') as oldest_pending\n from voice_event_buffer`);\n const ready = await sqlite.execute(`select count(*) as ready_calls from (\n select call_id\n from voice_event_buffer\n where forward_state='pending' and next_attempt_at<=unixepoch()\n group by call_id\n having max(case when event_type='call.ended' then 1 else 0 end)=1\n )`);\n return {\n ok: true,\n ...((totals.rows[0] as Record) || {}),\n ready_calls: Number((ready.rows[0] as Record | undefined)?.ready_calls || 0),\n };\n}\n\nexport async function replayBufferedVoiceCalls(limit = 2) {\n await ensureVoiceEventBuffer();\n if (!N8N_BASE || !TOOL_SECRET) {\n return { ok: false, replayed: 0, failed: 0, error: \"event_bridge_not_configured\" };\n }\n const safeLimit = Math.max(1, Math.min(8, Number(limit) || 2));\n const ready = await sqlite.execute({\n sql: `select call_id,max(created_at) as ended_at\n from voice_event_buffer\n where forward_state='pending' and next_attempt_at<=unixepoch()\n group by call_id\n having max(case when event_type='call.ended' then 1 else 0 end)=1\n order by ended_at asc\n limit :limit`,\n args: { limit: safeLimit },\n });\n let replayed = 0;\n let failed = 0;\n for (const callRow of ready.rows as Array>) {\n const callId = clean(callRow.call_id, 240);\n const events = await sqlite.execute({\n sql: `select event_type,payload_json,attempt_count\n from voice_event_buffer\n where call_id=:call_id and forward_state='pending'\n order by created_at asc`,\n args: { call_id: callId },\n });\n const rows = events.rows as Array>;\n const finalRow = [...rows].reverse().find((row) => row.event_type === \"call.ended\");\n let finalPayload: Record | null = null;\n try {\n const parsed = JSON.parse(String(finalRow?.payload_json || \"\"));\n if (parsed && typeof parsed === \"object\" && !Array.isArray(parsed)) finalPayload = parsed;\n } catch {\n finalPayload = null;\n }\n if (!finalPayload) {\n failed += 1;\n await sqlite.execute({\n sql: `update voice_event_buffer\n set attempt_count=attempt_count+1,last_error='invalid_final_payload',\n next_attempt_at=unixepoch()+86400\n where call_id=:call_id and forward_state='pending'`,\n args: { call_id: callId },\n });\n continue;\n }\n const attempt = Math.max(0, ...rows.map((row) => Number(row.attempt_count || 0))) + 1;\n const result = await postJson(\n `${N8N_BASE}/webhook/${EVENT_PATH}`,\n {\n ...finalPayload,\n buffered_event_count: rows.length,\n recovered_from_buffer: true,\n recovery_attempt: attempt,\n },\n 8_000,\n \"voice_call_replay\",\n \"callback_batch\",\n `recovery:voice:${callId}:attempt:${attempt}`,\n );\n if (result.ok === false) {\n failed += 1;\n const delay = Math.min(86400, 900 * (2 ** Math.min(attempt, 6)));\n await sqlite.execute({\n sql: `update voice_event_buffer\n set attempt_count=attempt_count+1,last_error=:last_error,\n next_attempt_at=unixepoch()+:delay\n where call_id=:call_id and forward_state='pending'`,\n args: {\n call_id: callId,\n last_error: clean(result.error || \"voice_replay_failed\", 240),\n delay,\n },\n });\n if (result.budget_blocked === true || result.error === \"n8n_circuit_open\") break;\n } else {\n replayed += 1;\n await markVoiceCallForwarded(callId);\n }\n }\n await sqlite.execute(\n \"delete from voice_event_buffer where forward_state='forwarded' and forwarded_at,\n call: CallContext,\n): Promise> {\n const buffered = await bufferVoiceEvent(event, call);\n if (buffered.event_type !== \"call.ended\") {\n return {\n ok: true,\n buffered: true,\n forwarded: false,\n pending_for_call: buffered.pending_for_call,\n };\n }\n if (!N8N_BASE || !TOOL_SECRET) {\n return {\n ok: true,\n buffered: true,\n forwarded: false,\n error: \"event_bridge_not_configured\",\n pending_for_call: buffered.pending_for_call,\n };\n }\n const result = await postJson(`${N8N_BASE}/webhook/${EVENT_PATH}`, {\n tenant_id: TENANT,\n provider: \"openai_realtime\",\n call_id: call.call_id,\n from_number: call.from_number,\n to_number: call.to_number,\n started_at: call.started_at,\n buffered_event_count: buffered.pending_for_call,\n ...event,\n }, 8_000, \"voice_call_final\");\n if (result.ok !== false) await markVoiceCallForwarded(call.call_id);\n return {\n ...result,\n buffered: true,\n forwarded: result.ok !== false,\n buffered_event_count: buffered.pending_for_call,\n };\n}\n\n\nexport async function deliverQuote(\n devisId: unknown,\n channel: unknown,\n): Promise> {\n const id = clean(devisId, 80);\n const deliveryChannel = clean(channel, 20).toLowerCase();\n if (!N8N_BASE || !TOOL_SECRET) {\n return { ok: false, action_completed: false, error: \"delivery_bridge_not_configured\" };\n }\n if (!/^[0-9a-f-]{36}$/i.test(id)) {\n return { ok: false, action_completed: false, error: \"invalid_quote_id\" };\n }\n if (!['sms', 'email'].includes(deliveryChannel)) {\n return { ok: false, action_completed: false, error: \"invalid_delivery_channel\" };\n }\n const result = await postJson(`${N8N_BASE}/webhook/sp-document-delivery-v1`, {\n document_type: \"quote\",\n devis_id: id,\n delivery_channel: deliveryChannel,\n }, deliveryChannel === \"email\" ? 18_000 : 12_000, `quote_delivery:${deliveryChannel}`);\n if (result.ok === false) {\n const error = clean(result.error, 120);\n return {\n ...result,\n action_completed: false,\n delivery_channel: deliveryChannel,\n safe_to_announce: true,\n assistant_message: error === \"sms_not_configured\"\n ? \"L’envoi par SMS n’est pas disponible sur ce numéro. Proposez l’envoi par email.\"\n : error === \"email_missing\"\n ? \"Il manque l’adresse email du client. Demandez-la, mettez la fiche à jour, puis relancez l’envoi.\"\n : \"Le devis est généré mais l’envoi n’a pas abouti. N’annoncez pas qu’il a été envoyé.\",\n };\n }\n return {\n ...result,\n ok: true,\n action_completed: true,\n delivery_channel: deliveryChannel,\n safe_to_announce: true,\n assistant_message: deliveryChannel === \"email\"\n ? \"Le devis estimatif a bien été envoyé par email.\"\n : \"Le devis estimatif a bien été envoyé par SMS.\",\n };\n}\n",[],[448,530],"e23a2fca-4b2d-4c37-93a4-e24b81e7092a","realtime-agent.ts","019f66f6-e506-776c-9df7-8706dc65b0f2",["D",1784138884418],"export type RealtimeTool = {\n type: \"function\";\n name: string;\n description: string;\n parameters: Record;\n};\n\nexport const ROLE_PROMPT = `# RÔLE\nTu es la secrétaire téléphonique d’une entreprise de piscine. Tu accueilles, comprends le besoin, qualifies le dossier, prends les rendez-vous, prépare les estimations et clôtures les appels comme le ferait une secrétaire expérimentée.\n\n# FAÇON DE PARLER\n- Parle comme une personne, jamais comme un serveur vocal.\n- Réponds généralement en une ou deux phrases courtes.\n- Pose une seule question à la fois, uniquement quand sa réponse est utile à l’action suivante.\n- Ne répète pas la demande du client sauf pour corriger une ambiguïté importante.\n- N’enchaîne pas les « très bien », « parfait », « d’accord » à chaque tour. Varie naturellement ou réponds directement.\n- Évite les listes orales, les formulations administratives et les longs récapitulatifs.\n- Laisse le client finir sa phrase et accepte qu’il t’interrompe.\n- Utilise un français de France simple, chaleureux et professionnel.\n\n# DATES ET HEURES À L’ORAL\n- Utilise uniquement le champ spoken_label renvoyé par l’outil.\n- Ne prononce jamais une heure sous la forme « zéro neuf heures », « neuf zéro zéro », « 09:00 » ou une date ISO.\n- Dis par exemple : « mercredi matin à neuf heures », « vers midi », « jeudi après-midi à quatorze heures trente ».\n- Quand un seul créneau demandé est libre, dis simplement qu’il est disponible ; ne propose pas trois autres horaires.\n\n# QUALIFICATION CLIENT\nLe numéro appelant est déjà connu du système.\n- Pour un nouveau client, demande naturellement le prénom, puis le nom, sans annoncer une liste de questions.\n- Demande une seule fois : « Je pourrai vous joindre sur le numéro avec lequel vous appelez ? »\n- Si la réponse est non, demande le numéro à utiliser et enregistre-le.\n- Demande l’adresse complète uniquement lorsqu’une intervention ou un rendez-vous sur place est envisagé.\n- Demande l’email uniquement si le client choisit l’envoi par email et qu’il n’est pas déjà connu.\n- Pour un client connu, ne redemande jamais une information déjà présente, sauf si tu dois vérifier qu’elle est toujours correcte.\n- Après avoir obtenu de nouvelles coordonnées, utilise update_client sans commenter l’opération technique.\n\n# CONDUITE DE L’APPEL\n1. Comprends d’abord le besoin. Une ou deux questions ciblées suffisent généralement.\n2. Enregistre la demande dès que le problème est clair.\n3. Agis immédiatement quand le client demande un rendez-vous, une estimation ou un envoi.\n4. Ne promets jamais une action avant le résultat de l’outil.\n\n# RENDEZ-VOUS\n- Si le client donne une date et une heure précises, vérifie ce créneau immédiatement.\n- S’il est disponible et que l’adresse est connue, réserve-le directement. Ne demande pas un « oui » supplémentaire.\n- Si le client choisit l’un des créneaux que tu viens de proposer, ce choix suffit pour réserver.\n- Demande une clarification seulement si la date, l’heure ou l’adresse est réellement ambiguë.\n- Si le créneau n’est plus libre, propose les nouvelles disponibilités sans recommencer toute la qualification.\n- Après succès, annonce une seule fois le rendez-vous avec le spoken_slot et l’adresse utile.\n- Si le client demande clairement d’annuler son prochain rendez-vous, utilise l’identifiant présent dans le contexte CRM, annule-le immédiatement et confirme l’annulation une seule fois.\n\n# DEVIS ESTIMATIF\n- Après avoir compris le problème, tu peux proposer spontanément une estimation utile, sans insister.\n- Utilise estimate_quote : annonce la fourchette TTC une seule fois et précise brièvement qu’elle reste à confirmer après diagnostic.\n- Demande ensuite : « Vous préférez que je vous l’envoie par SMS ou par email ? »\n- Pour un email, collecte l’adresse manquante puis mets la fiche à jour.\n- Utilise create_and_send_quote pour générer le vrai devis estimatif dans le format du cockpit et déclencher l’envoi choisi.\n- N’annonce l’envoi que si l’outil confirme action_completed=true.\n- Si le SMS n’est pas disponible, propose simplement l’email, sans explication technique.\n\n# VERROU DE COMPLÉTUDE\n- Ne termine jamais un appel utile avec seulement une formule vague. Avant complete_call, assure-toi d’avoir un résumé factuel, l’intention et le niveau d’urgence.\n- Pour une demande à traiter, le besoin doit être clair, l’identité utile doit être connue et la demande doit avoir été enregistrée ou mise en attente par un outil.\n- Pour un rendez-vous sur place, collecte l’adresse complète et le créneau exact. N’utilise appointment_booked que si l’outil confirme réellement la réservation.\n- N’utilise quote_sent que si l’envoi est réellement confirmé. Pour un email, l’adresse email doit être connue.\n- Une synchronisation en attente n’est ni une réservation ni un envoi confirmé : dis simplement que la demande est prise en charge et reste à confirmer.\n- Si complete_call répond needs_more_information=true, ne prends pas congé. Pose uniquement la next_question indiquée ou exécute la required_action, puis réessaie.\n- Une exception de qualification n’est permise que si le client refuse explicitement de répondre, devient abusif, si une urgence impose de conclure vite, ou si aucune action métier n’était nécessaire.\n\n# FIN D’APPEL\n- Quand le besoin est traité, fais un récapitulatif d’une seule phrase avec uniquement les actions réellement réalisées.\n- Ne demande pas plusieurs fois s’il reste autre chose.\n- Si le client remercie, dit au revoir ou n’a plus de demande, utilise complete_call seulement après le verrou de complétude.\n- Après complete_call autorisé, prononce une formule de fin courte et naturelle, puis laisse le système raccrocher.\n\n# LIMITES ET SÉCURITÉ\nTu traites uniquement les sujets liés à la piscine et à l’entreprise : dépannage, entretien, eau, équipements, travaux, rendez-vous, devis et suivi.\nN’invente jamais un diagnostic, un tarif ferme, une disponibilité, un envoi ou une garantie.\nEn cas de risque électrique, local technique inondé, fuite majeure ou danger corporel, conseille brièvement de sécuriser la zone sans se mettre en danger puis crée une demande urgente ou un rappel humain.\nNe prononce jamais le nom d’un outil, du JSON, un identifiant ou un message d’erreur.`;\n\nconst objectSchema = (properties: Record, required: string[] = []) => ({\n type: \"object\",\n properties,\n required,\n additionalProperties: false,\n});\n\nconst text = (description: string) => ({ type: \"string\", description });\n\nexport const REALTIME_TOOLS: RealtimeTool[] = [\n {\n type: \"function\",\n name: \"client_context\",\n description: \"Lire la fiche liée au numéro appelant et les informations encore manquantes. Lecture seule.\",\n parameters: objectSchema({}),\n },\n {\n type: \"function\",\n name: \"update_client\",\n description: \"Enregistrer immédiatement les coordonnées ou préférences que le client vient de communiquer. Ne pas redemander les champs déjà connus.\",\n parameters: objectSchema({\n first_name: text(\"Prénom du client.\"),\n last_name: text(\"Nom de famille du client.\"),\n email: text(\"Adresse email communiquée.\"),\n address: text(\"Numéro et voie de l’adresse d’intervention.\"),\n postal_code: text(\"Code postal.\"),\n city: text(\"Ville.\"),\n phone_reachable: { type: \"boolean\", description: \"Vrai si le client confirme être joignable sur le numéro appelant.\" },\n alternate_phone: text(\"Autre numéro à utiliser si le numéro appelant ne convient pas.\"),\n preferred_contact_channel: { type: \"string\", enum: [\"telephone\", \"sms\", \"email\"], description: \"Canal préféré exprimé par le client.\" },\n }),\n },\n {\n type: \"function\",\n name: \"create_lead\",\n description: \"Créer ou compléter la demande dès que le besoin piscine est compris.\",\n parameters: objectSchema({\n first_name: text(\"Prénom si connu.\"),\n last_name: text(\"Nom si connu.\"),\n customer_name: text(\"Nom complet si le client l’a donné en une seule fois.\"),\n address: text(\"Adresse si connue.\"),\n postal_code: text(\"Code postal si connu.\"),\n city: text(\"Ville si connue.\"),\n pool_type: text(\"Type de bassin ou installation si connu.\"),\n problem: text(\"Description factuelle du besoin.\"),\n intent: { type: \"string\", enum: [\"depannage\", \"entretien\", \"devis\", \"rendez_vous\", \"construction\", \"renovation\", \"suivi\", \"autre\"] },\n urgency: { type: \"string\", enum: [\"basse\", \"normale\", \"haute\", \"urgente\"] },\n }, [\"problem\", \"intent\", \"urgency\"]),\n },\n {\n type: \"function\",\n name: \"check_availability\",\n description: \"Vérifier le créneau exact demandé ou chercher les premiers créneaux libres. Si une date et une heure sont données, les transmettre précisément.\",\n parameters: objectSchema({\n appointment_datetime: text(\"Date et heure souhaitées au format ISO 8601 avec fuseau horaire.\"),\n preferred_period: { type: \"string\", enum: [\"matin\", \"apres_midi\", \"indifferent\"] },\n duration_min: { type: \"number\", description: \"Durée estimée, généralement 60 minutes.\" },\n }),\n },\n {\n type: \"function\",\n name: \"book_appointment\",\n description: \"Réserver le créneau exact demandé ou sélectionné. Aucun oui supplémentaire n’est requis quand le choix du client est déjà explicite.\",\n parameters: objectSchema({\n appointment_datetime: text(\"Créneau exact au format ISO 8601, repris du résultat de disponibilité.\"),\n address: text(\"Adresse d’intervention si elle vient d’être communiquée.\"),\n appointment_type: text(\"Motif court du rendez-vous.\"),\n duration_min: { type: \"number\", description: \"Durée du créneau.\" },\n first_name: text(\"Prénom si nouvellement communiqué.\"),\n last_name: text(\"Nom si nouvellement communiqué.\"),\n phone_reachable: { type: \"boolean\", description: \"Confirmation de joignabilité sur le numéro appelant si connue.\" },\n alternate_phone: text(\"Numéro alternatif si nécessaire.\"),\n }, [\"appointment_datetime\"]),\n },\n {\n type: \"function\",\n name: \"cancel_appointment\",\n description: \"Annuler un rendez-vous existant lorsque le client le demande clairement. Utiliser uniquement l’identifiant du prochain rendez-vous présent dans le contexte CRM ou retourné pendant cet appel.\",\n parameters: objectSchema({\n appointment_id: text(\"Identifiant interne du rendez-vous à annuler.\"),\n reason: text(\"Motif court donné par le client, si disponible.\"),\n }, [\"appointment_id\"]),\n },\n {\n type: \"function\",\n name: \"estimate_quote\",\n description: \"Calculer une fourchette estimative à partir du problème décrit et du catalogue interne. Lecture seule, montant non contractuel.\",\n parameters: objectSchema({\n problem: text(\"Problème, équipement ou prestation à estimer avec les précisions données par le client.\"),\n pool_type: text(\"Type de bassin ou équipement si connu.\"),\n }, [\"problem\"]),\n },\n {\n type: \"function\",\n name: \"create_and_send_quote\",\n description: \"Créer le devis estimatif dans le format du cockpit puis l’envoyer réellement par le canal choisi.\",\n parameters: objectSchema({\n problem: text(\"Description complète servant de base à l’estimation.\"),\n delivery_channel: { type: \"string\", enum: [\"sms\", \"email\"], description: \"Canal choisi explicitement par le client.\" },\n first_name: text(\"Prénom.\"),\n last_name: text(\"Nom de famille.\"),\n customer_name: text(\"Nom complet si fourni en une seule fois.\"),\n email: text(\"Email obligatoire pour un envoi par email s’il n’est pas déjà en fiche.\"),\n address: text(\"Adresse si connue.\"),\n postal_code: text(\"Code postal si connu.\"),\n city: text(\"Ville si connue.\"),\n pool_type: text(\"Type de bassin ou équipement.\"),\n phone_reachable: { type: \"boolean\", description: \"Joignabilité sur le numéro appelant.\" },\n alternate_phone: text(\"Numéro alternatif.\"),\n }, [\"problem\", \"delivery_channel\"]),\n },\n {\n type: \"function\",\n name: \"knowledge_lookup\",\n description: \"Consulter une information métier validée avant une réponse technique ou commerciale précise.\",\n parameters: objectSchema({ query: text(\"Question métier courte.\") }, [\"query\"]),\n },\n {\n type: \"function\",\n name: \"transfer_to_human\",\n description: \"Transférer vers un humain si possible ou créer une demande de rappel.\",\n parameters: objectSchema({\n problem: text(\"Raison factuelle du transfert ou du rappel.\"),\n urgency: { type: \"string\", enum: [\"normale\", \"haute\", \"urgente\"] },\n }, [\"problem\"]),\n },\n {\n type: \"function\",\n name: \"complete_call\",\n description: \"Enregistrer le résultat final puis terminer proprement l’appel quand aucune action ou question n’est encore en attente.\",\n parameters: objectSchema({\n summary: text(\"Résumé court : identité utile, besoin, coordonnées qualifiées et actions réellement terminées.\"),\n intent: { type: \"string\", enum: [\"depannage\", \"entretien\", \"devis\", \"rendez_vous\", \"construction\", \"renovation\", \"suivi\", \"information\", \"autre\"], description: \"Intention principale normalisée.\" },\n urgency: { type: \"string\", enum: [\"basse\", \"normale\", \"haute\", \"urgente\"] },\n sentiment: { type: \"string\", enum: [\"positif\", \"neutre\", \"inquiet\", \"frustre\", \"urgent\"] },\n closing_reason: { type: \"string\", enum: [\"resolved\", \"appointment_booked\", \"quote_sent\", \"callback_created\", \"client_finished\"] },\n qualification_exception: {\n type: \"string\",\n enum: [\"caller_refused\", \"caller_abusive\", \"emergency_handled\", \"no_action_needed\"],\n description: \"À renseigner uniquement si cette exception a réellement eu lieu ; ne jamais l’utiliser pour éviter une question utile.\"\n },\n }, [\"summary\", \"intent\", \"urgency\", \"closing_reason\"]),\n },\n];\n\nexport function buildSessionInstructions(context: Record | null, fromNumber: string): string {\n const compact = context ? JSON.stringify(context).slice(0, 8000) : \"indisponible\";\n const nowParis = new Intl.DateTimeFormat(\"fr-FR\", {\n timeZone: \"Europe/Paris\",\n dateStyle: \"full\",\n timeStyle: \"long\",\n }).format(new Date());\n return `${ROLE_PROMPT}\\n\\n# CONTEXTE DE CET APPEL\\nDate et heure à Paris : ${nowParis}.\\nNuméro appelant : ${fromNumber || \"inconnu\"}.\\nFiche CRM et informations manquantes : ${compact}.\\nLe contexte CRM est fiable. Utilise-le silencieusement et ne redemande que ce qui manque pour l’action en cours.`;\n}\n\nexport function buildAcceptConfig(model: string, voice: string) {\n return {\n type: \"realtime\",\n model,\n instructions: ROLE_PROMPT,\n output_modalities: [\"audio\"],\n audio: {\n input: {\n turn_detection: {\n type: \"semantic_vad\",\n eagerness: \"medium\",\n create_response: true,\n interrupt_response: true,\n },\n },\n output: { voice },\n },\n tools: REALTIME_TOOLS,\n tool_choice: \"auto\",\n };\n}\n",[],[448,537],"d44c3bed-f1ef-494c-a37d-8b91f185a1b3","owner-ui.ts","019f66f6-e506-776c-9df7-814bcb31bc57",36,["D",1784139702745],11,"export const CLIENT_OWNER_BOOT = String.raw`\n(()=>{try{\n const fragment=new URLSearchParams(location.hash.slice(1));\n const accessToken=fragment.get('access_token')||'';\n const refreshToken=fragment.get('refresh_token')||'';\n const error=fragment.get('error')||'';\n if(accessToken||refreshToken||error){\n if(accessToken&&refreshToken){\n const expiresIn=Math.max(60,Math.min(86400,Number(fragment.get('expires_in')||3600)));\n sessionStorage.setItem('piscine_owner_auth_v1',JSON.stringify({\n access_token:accessToken,\n refresh_token:refreshToken,\n expires_at:Date.now()+expiresIn*1000\n }));\n sessionStorage.removeItem('piscine_owner_auth_error_v1');\n }else{\n sessionStorage.removeItem('piscine_owner_auth_v1');\n sessionStorage.setItem(\n 'piscine_owner_auth_error_v1',\n String(error||'owner_auth_callback_failed').slice(0,120)\n );\n }\n sessionStorage.setItem('piscine_owner_auth_callback_v1','1');\n const next=new URL(location.href);\n next.searchParams.delete('owner_auth');\n history.replaceState(null,'',next.pathname+(next.search||'')+'#owner');\n }\n}catch{\n sessionStorage.removeItem('piscine_owner_auth_v1');\n}})();\n`;\n\nexport const CSS_OWNER = String.raw`\n.owner-hero-actions{display:flex;gap:9px;align-items:center;flex-wrap:wrap}\n.owner-status-grid{grid-template-columns:repeat(4,minmax(0,1fr));margin-bottom:16px}\n.owner-status-card{padding:16px}.owner-status-card span{display:block;color:var(--muted);font-size:10px;margin-bottom:6px}.owner-status-card strong{font-size:15px}.owner-status-card small{display:block;color:var(--muted);margin-top:5px}\n.owner-voice{display:grid;gap:16px;padding:20px}.owner-orb{width:84px;height:84px;border-radius:50%;display:grid;place-items:center;margin:auto;background:radial-gradient(circle at 35% 30%,#65efd7,#159b87 55%,#0e4b43);box-shadow:0 0 0 10px rgba(53,209,181,.06),0 18px 45px rgba(0,0,0,.28);font-size:30px}.owner-orb.live{animation:ownerPulse 1.3s ease-in-out infinite}.owner-orb.blocked{filter:grayscale(.65);opacity:.58}@keyframes ownerPulse{50%{transform:scale(1.06);box-shadow:0 0 0 18px rgba(53,209,181,.03),0 20px 50px rgba(0,0,0,.3)}}\n.owner-voice-copy{text-align:center}.owner-voice-copy h2{margin:0 0 5px;font-size:18px}.owner-voice-copy p{margin:0;color:var(--muted);font-size:11px}.owner-voice-actions{display:flex;justify-content:center;gap:9px}.owner-transcript{min-height:120px;max-height:260px;overflow:auto;border:1px solid var(--line);background:#0b141b;border-radius:13px;padding:13px;color:#c8d7dc;white-space:pre-wrap;font-size:12px}.owner-transcript:empty:before{content:\"La transcription de la session apparaîtra ici.\";color:var(--muted)}\n.owner-command-grid{display:grid;grid-template-columns:repeat(2,minmax(0,1fr));gap:9px;padding:16px}.owner-command{border:1px solid var(--line);background:#0d161d;color:var(--ink);border-radius:13px;padding:13px;text-align:left}.owner-command b{display:block}.owner-command span{display:block;color:var(--muted);font-size:10px;margin-top:3px}.owner-command:hover:not(:disabled){border-color:#367b6e;background:#15312e}\n.owner-result{padding:14px 17px;color:var(--muted);font-size:11px;border-top:1px solid var(--line);white-space:pre-wrap}.owner-control-list{display:grid}.owner-control-row{display:grid;grid-template-columns:minmax(0,1fr) auto;gap:10px;padding:12px 16px;border-bottom:1px solid var(--line)}.owner-control-row:last-child{border-bottom:0}.owner-control-row b{display:block;font-size:11px}.owner-control-row small{display:block;color:var(--muted);margin-top:3px}.owner-blockers{display:grid;gap:8px;padding:14px}.owner-blocker{display:flex;gap:9px;align-items:center;padding:10px;border-radius:11px;background:var(--warnbg);color:var(--warn);font-size:11px}.owner-blocker.ok{background:var(--okbg);color:var(--ok)}\n.owner-delivery-kpis{grid-template-columns:repeat(4,minmax(0,1fr));padding:16px}.owner-delivery-kpi{padding:13px;border:1px solid var(--line);background:#0d161d;border-radius:13px}.owner-delivery-kpi span{display:block;color:var(--muted);font-size:10px}.owner-delivery-kpi strong{display:block;font-size:24px;margin-top:4px}.owner-delivery-kpi.ok strong{color:var(--ok)}.owner-delivery-kpi.warn strong{color:var(--warn)}.owner-delivery-kpi.bad strong{color:var(--danger)}.owner-safe-note{margin:0 16px 16px;padding:11px 12px;border-radius:12px;background:#0d161d;color:var(--muted);font-size:11px}.owner-safe-note b{color:var(--ink)}.owner-test-blockers{display:grid;gap:7px;margin-top:13px}.owner-test-blockers .owner-blocker{padding:8px 10px}\n.owner-activation{overflow:hidden}.owner-activation-head{display:flex;align-items:flex-start;justify-content:space-between;gap:16px;padding:18px;border-bottom:1px solid var(--line)}.owner-activation-head h2{margin:0 0 4px}.owner-activation-head p{margin:0;color:var(--muted);font-size:11px}.owner-activation-grid{display:grid;grid-template-columns:repeat(2,minmax(0,1fr));gap:1px;background:var(--line)}.owner-activation-step{display:grid;grid-template-columns:minmax(0,1fr) auto;align-items:center;gap:12px;padding:14px 16px;background:var(--panel)}.owner-activation-step b{display:block;font-size:12px}.owner-activation-step small{display:block;color:var(--muted);margin-top:3px}.owner-activation-next{padding:16px;border-top:1px solid var(--line)}.owner-activation-next h3{margin:0 0 10px;font-size:12px}.owner-next-list{display:grid;gap:7px}.owner-next-item{display:flex;align-items:center;gap:10px;padding:10px 12px;border-radius:11px;background:#0d161d;color:var(--muted);font-size:11px}.owner-next-index{width:22px;height:22px;border-radius:8px;background:var(--accent2);color:var(--accent);display:grid;place-items:center;font-weight:900;flex:0 0 auto}\n.owner-auth-card{display:flex;align-items:center;justify-content:space-between;gap:20px;padding:17px 18px}.owner-auth-copy{min-width:0}.owner-auth-copy h2{margin:3px 0 5px;font-size:15px}.owner-auth-copy p{margin:0;color:var(--muted);font-size:11px}.owner-auth-copy small{display:block;margin-top:7px;color:var(--muted)}.owner-auth-actions{display:flex;align-items:center;justify-content:flex-end;gap:9px;flex-wrap:wrap}.owner-auth-actions .pill{white-space:nowrap}\n@media(max-width:900px){.owner-status-grid,.owner-delivery-kpis{grid-template-columns:repeat(2,minmax(0,1fr))}.owner-command-grid,.owner-activation-grid{grid-template-columns:1fr}.owner-auth-card{align-items:flex-start;flex-direction:column}.owner-auth-actions{justify-content:flex-start}}\n`;\n\nexport const CLIENT_OWNER = String.raw`\ntitles.owner='Assistante IA';\nconst ownerState={caps:null,pc:null,stream:null,channel:null,audio:null,loading:false,activationLoading:false,activationLoaded:false,auth:null,authPromise:null,toolCalls:new Set()};\nconst ownerLabels={\n owner_direct_gateway_disabled:\"La console directe reste coupée.\",\n owner_direct_gateway_not_configured:\"La passerelle directe Supabase doit être configurée.\",\n owner_voice_mode_disabled:\"La commande vocale dirigeant reste verrouillée pendant la phase de sécurisation.\",\n openai_api_not_configured:\"La connexion OpenAI Realtime manque.\",\n owner_staff_identity_missing:\"L’identité staff technique manque.\",\n owner_strong_identity_required_for_commit:\"Une identité forte liée au compte dirigeant est requise avant toute écriture réelle.\",\n owner_strong_identity_required_for_voice:\"La session e-mail sécurisée est requise avant la voix dirigeant.\",\n owner_email_auth_not_configured:\"La connexion e-mail propriétaire doit être configurée.\",\n owner_strong_identity_invalid:\"La session sécurisée a expiré.\",\n owner_email_not_allowlisted:\"Cette adresse n’est pas autorisée pour le compte propriétaire.\",\n owner_commit_permission_disabled:\"Les permissions d’écriture réelle restent volontairement désactivées.\"\n};\nfunction ownerText(value,fallback){return String(value==null?(fallback||''):value)}\nfunction ownerSetText(selector,value){const el=q(selector);if(el)el.textContent=ownerText(value)}\nfunction ownerSetTranscript(line,append){const el=q('#ownerTranscript');if(!el)return;if(append)el.textContent+=ownerText(line);else el.textContent=ownerText(line);el.scrollTop=el.scrollHeight}\nconst OWNER_AUTH_STORAGE='piscine_owner_auth_v1';\nfunction ownerAuthLoad(){\n if(ownerState.auth)return ownerState.auth;\n try{\n const parsed=JSON.parse(sessionStorage.getItem(OWNER_AUTH_STORAGE)||'null');\n if(!parsed||typeof parsed!=='object')return null;\n const access=ownerText(parsed.access_token),refresh=ownerText(parsed.refresh_token),expires=Number(parsed.expires_at||0);\n if(access.length<20||refresh.length<20||!Number.isFinite(expires))return null;\n ownerState.auth={access_token:access,refresh_token:refresh,expires_at:expires};\n return ownerState.auth;\n }catch{return null}\n}\nfunction ownerAuthSave(payload){\n const access=ownerText(payload.access_token),refresh=ownerText(payload.refresh_token);\n const expiresIn=Math.max(60,Math.min(86400,Number(payload.expires_in||3600)));\n if(access.length<20||refresh.length<20)throw new Error('owner_auth_invalid_response');\n ownerState.auth={access_token:access,refresh_token:refresh,expires_at:Date.now()+expiresIn*1000};\n sessionStorage.setItem(OWNER_AUTH_STORAGE,JSON.stringify(ownerState.auth));\n sessionStorage.removeItem('piscine_owner_auth_error_v1');\n return ownerState.auth;\n}\nfunction ownerAuthClear(){\n ownerState.auth=null;\n sessionStorage.removeItem(OWNER_AUTH_STORAGE);\n}\nasync function ownerAuthToken(){\n const current=ownerAuthLoad();\n if(!current)return '';\n if(current.expires_at>Date.now()+90000)return current.access_token;\n if(ownerState.authPromise)return ownerState.authPromise;\n ownerState.authPromise=(async()=>{\n const response=await fetch('/api/owner/auth/refresh',{\n method:'POST',\n headers:{'content-type':'application/json','x-csrf-token':csrf},\n body:JSON.stringify({refresh_token:current.refresh_token})\n });\n const result=await response.json();\n if(!response.ok||result.ok===false){ownerAuthClear();return ''}\n return ownerAuthSave(result).access_token;\n })();\n try{return await ownerState.authPromise}catch{ownerAuthClear();return ''}finally{ownerState.authPromise=null}\n}\nfunction ownerRenderAuth(auth){\n const configured=Boolean(auth&&auth.configured);\n const verified=Boolean(auth&&auth.verified);\n const local=ownerAuthLoad();\n const callbackError=sessionStorage.getItem('piscine_owner_auth_error_v1')||'';\n const pill=q('#ownerAuthPill'),request=q('#ownerAuthRequest'),logout=q('#ownerAuthLogout');\n if(pill){\n pill.textContent=verified?'Identité vérifiée':configured?'À confirmer':'À configurer';\n pill.className='pill '+(verified?'ok':'warn');\n }\n ownerSetText(\n '#ownerAuthCopy',\n verified\n ?'Cette session a été vérifiée par Supabase Auth. Les permissions sensibles restent séparément verrouillées.'\n :callbackError\n ?'Le lien n’a pas pu être validé. Demandez un nouveau lien sécurisé.'\n :'Confirmez votre adresse e-mail avec un lien à usage unique. Aucun mot de passe n’est stocké.'\n );\n ownerSetText('#ownerAuthMeta',auth&&auth.email_hint?'Compte autorisé : '+ownerText(auth.email_hint):'Compte propriétaire sécurisé');\n if(request){request.hidden=verified;request.disabled=!configured;request.textContent='Recevoir mon lien sécurisé'}\n if(logout){logout.hidden=!local;logout.disabled=false}\n if(verified)sessionStorage.removeItem('piscine_owner_auth_error_v1');\n}\nasync function ownerRequestMagicLink(){\n const button=q('#ownerAuthRequest');\n if(button){button.disabled=true;button.textContent='Envoi en cours…'}\n try{\n const response=await fetch('/api/owner/auth/request',{\n method:'POST',\n headers:{'content-type':'application/json','x-csrf-token':csrf},\n body:'{}'\n });\n const result=await response.json();\n if(!response.ok||result.ok===false)throw new Error(result.error||'owner_magic_link_request_failed');\n ownerSetText('#ownerAuthCopy','Lien sécurisé envoyé. Ouvrez l’e-mail dans ce navigateur pour confirmer votre identité.');\n toast('Lien de connexion envoyé');\n }catch(error){\n toast(ownerLabels[ownerText(error.message)]||ownerText(error.message),false);\n }finally{\n if(button){button.textContent='Recevoir mon lien sécurisé';setTimeout(()=>{button.disabled=false},60000)}\n }\n}\nasync function ownerLogoutStrongIdentity(){\n const token=await ownerAuthToken();\n try{\n await fetch('/api/owner/auth/logout',{\n method:'POST',\n headers:{'x-csrf-token':csrf,...(token?{'x-owner-access-token':token}:{})}\n });\n }catch{}\n ownerAuthClear();\n ownerState.activationLoaded=false;\n await ownerFetchCaps();\n toast('Session propriétaire déconnectée');\n}\nfunction ownerRenderCaps(caps){\n ownerState.caps=caps;\n ownerRenderAuth(caps.owner_auth||{});\n const consoleAvailable=Boolean(caps.console_available);\n const voiceAvailable=Boolean(caps.voice_available);\n const pillEl=q('#ownerModePill');\n if(pillEl){\n pillEl.textContent=voiceAvailable?'Console + voix':consoleAvailable?'Console directe':'Préparation';\n pillEl.className='pill '+(consoleAvailable?'ok':'warn');\n }\n ownerSetText('#ownerModeValue',consoleAvailable?'Console active':'Console coupée');\n ownerSetText('#ownerGatewayValue',consoleAvailable?'Direct Supabase':'À configurer');\n ownerSetText('#ownerIdentityValue',caps.strong_identity_verified?'Identité forte':'Lecture sécurisée');\n ownerSetText('#ownerVoiceValue',voiceAvailable?'Prête':'Verrouillée');\n ownerSetText('#ownerModelMeta',ownerText(caps.model)+' · '+ownerText(caps.voice));\n const blockers=q('#ownerBlockers');\n if(blockers){\n blockers.replaceChildren();\n const list=Array.isArray(caps.blockers)?caps.blockers:[];\n if(!list.length){\n const ok=document.createElement('div');ok.className='owner-blocker ok';ok.textContent='Tous les contrôles sont satisfaits.';blockers.appendChild(ok);\n }else{\n list.forEach(code=>{const row=document.createElement('div');row.className='owner-blocker';row.textContent=ownerLabels[code]||ownerText(code);blockers.appendChild(row)});\n }\n }\n const start=q('#ownerVoiceStart'),orb=q('#ownerOrb');\n if(start){start.disabled=!voiceAvailable;start.textContent=voiceAvailable?'Parler à l’assistante':'Voix verrouillée'}\n if(orb)orb.classList.toggle('blocked',!voiceAvailable);\n qa('[data-owner-action]').forEach(button=>{button.disabled=!consoleAvailable});\n}\nasync function ownerFetchCaps(){\n if(ownerState.loading)return;\n ownerState.loading=true;\n try{\n const token=await ownerAuthToken();\n const response=await fetch('/api/owner/capabilities',{headers:{accept:'application/json',...(token?{'x-owner-access-token':token}:{})}});\n const result=await response.json();\n if(!response.ok||result.ok===false)throw new Error(result.error||'capacites_indisponibles');\n ownerRenderCaps(result);\n if(result.console_available&&!ownerState.activationLoaded)void ownerLoadActivation(false).catch(error=>toast(ownerText(error.message),false));\n }catch(error){\n ownerSetText('#ownerVoiceValue','Erreur');\n ownerSetTranscript('État propriétaire indisponible : '+ownerText(error.message),false);\n }finally{ownerState.loading=false}\n}\nasync function ownerAction(action,data){\n const token=await ownerAuthToken();\n const response=await fetch('/api/owner/action',{\n method:'POST',\n headers:{'content-type':'application/json','x-csrf-token':csrf,...(token?{'x-owner-access-token':token}:{})},\n body:JSON.stringify({action:action,data:data||{}})\n });\n const result=await response.json();\n if(!response.ok||result.ok===false)throw new Error(result.assistant_message||result.error||'action_proprietaire_refusee');\n return result;\n}\nasync function ownerLoadActivation(force){\n if(ownerState.activationLoading||(!force&&ownerState.activationLoaded))return;\n ownerState.activationLoading=true;\n try{\n const result=await ownerAction('get_activation_readiness',{});\n ownerRenderActivation(result.data||{});\n ownerState.activationLoaded=true;\n return result;\n }catch(error){\n ownerSetText('#ownerActivationState','Indisponible');\n const root=q('#ownerActivationSteps');\n if(root)root.innerHTML='

Diagnostic indisponible'+esc(ownerText(error.message))+'

Erreur

';\n throw error;\n }finally{ownerState.activationLoading=false}\n}\nfunction ownerRenderDefinition(selector,pairs){\n const root=q(selector);if(!root)return;root.replaceChildren();\n pairs.forEach(pair=>{const dt=document.createElement('dt');dt.textContent=pair[0];const dd=document.createElement('dd');dd.textContent=pair[1];root.append(dt,dd)});\n}\nfunction ownerDeliveryPill(group,label){\n const state=document.createElement('span');\n state.className='pill '+(group==='delivered'?'ok':group==='failed'?'bad':group==='waiting'?'warn':'info');\n state.textContent=ownerText(label,'Inconnu');\n return state;\n}\nfunction ownerRenderDelivery(delivery){\n const counts=delivery&&delivery.counts||{};\n ownerSetText('#ownerDeliveryWaiting',counts.waiting||0);\n ownerSetText('#ownerDeliverySent',counts.sent||0);\n ownerSetText('#ownerDeliveryDelivered',counts.delivered||0);\n ownerSetText('#ownerDeliveryFailed',counts.failed||0);\n ownerSetText('#ownerDeliveryAlertCount',counts.open_delivery_alerts||0);\n\n const recent=Array.isArray(delivery&&delivery.recent_messages)?delivery.recent_messages:[];\n const recentRoot=q('#ownerDeliveryRecent');\n if(recentRoot){\n recentRoot.replaceChildren();\n if(!recent.length){const empty=document.createElement('div');empty.className='empty';empty.textContent='Aucun SMS réel suivi pour le moment.';recentRoot.appendChild(empty)}\n recent.forEach(item=>{\n const row=document.createElement('div');row.className='owner-control-row';\n const copy=document.createElement('div');\n const title=document.createElement('b');\n title.textContent=ownerText(item.document_number,item.message_id_suffix?'SMS …'+ownerText(item.message_id_suffix):'SMS');\n const meta=document.createElement('small');\n meta.textContent=[ownerText(item.provider_status),dt(item.occurred_at)].filter(Boolean).join(' · ');\n copy.append(title,meta);\n row.append(copy,ownerDeliveryPill(item.state_group,item.state_label));\n recentRoot.appendChild(row);\n });\n }\n\n const failures=Array.isArray(delivery&&delivery.open_failures)?delivery.open_failures:[];\n const failureRoot=q('#ownerDeliveryFailures');\n if(failureRoot){\n failureRoot.replaceChildren();\n if(!failures.length){const empty=document.createElement('div');empty.className='empty';empty.textContent='Aucune alerte de livraison ouverte.';failureRoot.appendChild(empty)}\n failures.forEach(item=>{\n const row=document.createElement('div');row.className='owner-control-row';\n const copy=document.createElement('div');\n const title=document.createElement('b');title.textContent=ownerText(item.title,'Échec de livraison SMS');\n const meta=document.createElement('small');\n meta.textContent=['SMS …'+ownerText(item.message_id_suffix,'—'),ownerText(item.error_code,'code inconnu'),dt(item.occurred_at)].join(' · ');\n copy.append(title,meta);\n row.append(copy,ownerDeliveryPill('failed','À traiter'));\n failureRoot.appendChild(row);\n });\n }\n\n const plan=delivery&&delivery.test_sms_plan||{};\n const completed=plan.approval_status==='executed';\n const safeReady=Boolean(plan.ready_to_approve&&plan.recipient_configured&&plan.send_enabled&&plan.template_enabled&&plan.outbound_enabled);\n const planPill=q('#ownerTestSmsPill');\n if(planPill){planPill.className='pill '+(completed?'ok':safeReady?'warn':'info');planPill.textContent=completed?'Test livré':safeReady?'Prêt à valider':'Bloqué en sécurité'}\n ownerRenderDefinition('#ownerTestSmsSummary',[\n ['Préparation',plan.prepared?'Créée':'À créer'],\n ['Modèle',plan.template_enabled?'Activé':'Désactivé'],\n ['Destinataire',plan.recipient_configured?'Configuré':'À renseigner'],\n ['Validation humaine',plan.approval_status==='executed'?'Consommée':plan.approval_status==='approved'?'Accordée':plan.approval_status==='pending'?'En attente':'Requise'],\n ['Limite',ownerText(plan.max_messages,1)+' SMS maximum'],\n ['Relance automatique',plan.automatic_retry?'Activée':'Interdite'],\n ['Canaux sortants',plan.outbound_enabled?'Activés':'Coupés']\n ]);\n const blockerRoot=q('#ownerTestSmsBlockers');\n if(blockerRoot){\n blockerRoot.replaceChildren();\n const labels={\n template_disabled:'Le modèle de test reste désactivé.',\n human_approval_missing:'Une validation humaine est obligatoire.',\n recipient_missing:'Aucun numéro de test n’est enregistré.',\n send_disabled:'L’exécution de l’envoi est désactivée.',\n outbound_disabled:'Les communications sortantes restent coupées.',\n not_prepared:'Le plan de test n’est pas encore préparé.'\n };\n const blocked=Array.isArray(plan.blocked_reasons)?plan.blocked_reasons:[];\n blocked.forEach(code=>{const row=document.createElement('div');row.className='owner-blocker';row.textContent=labels[code]||ownerText(code);blockerRoot.appendChild(row)});\n }\n ownerSetText('#ownerTestSmsNote',completed?'Un SMS a été livré. Le quota est consommé et le mécanisme est refermé.':safeReady?'Le test attend votre validation explicite.':'Aucun SMS ne peut partir depuis ce bloc.');\n}\nfunction ownerRenderAutonomy(snapshot){\n const approvals=Array.isArray(snapshot.pending_approvals)?snapshot.pending_approvals:[];\n const approvalRoot=q('#ownerApprovalList');ownerSetText('#ownerApprovalCount',approvals.length);\n if(approvalRoot){\n approvalRoot.replaceChildren();\n if(!approvals.length){const empty=document.createElement('div');empty.className='empty';empty.textContent='Aucune validation en attente.';approvalRoot.appendChild(empty)}\n approvals.forEach(item=>{const row=document.createElement('div');row.className='owner-control-row';const copy=document.createElement('div');const title=document.createElement('b');title.textContent=ownerText(item.summary,item.action_key);const preparation=item.action_key==='send_twilio_test_sms';const meta=document.createElement('small');meta.textContent=preparation?'Préparation sans envoi · destinataire manquant':ownerText(item.action_key)+' · risque '+ownerText(item.risk_level);copy.append(title,meta);const state=document.createElement('span');state.className='pill '+(preparation?'info':'warn');state.textContent=preparation?'À configurer':'À valider';row.append(copy,state);approvalRoot.appendChild(row)});\n }\n const rules=Array.isArray(snapshot.automation_candidates)?snapshot.automation_candidates:[];\n const automationRoot=q('#ownerAutomationList');ownerSetText('#ownerAutomationCount',rules.length);\n if(automationRoot){\n automationRoot.replaceChildren();\n if(!rules.length){const empty=document.createElement('div');empty.className='empty';empty.textContent='Aucune règle analysée.';automationRoot.appendChild(empty)}\n rules.forEach(rule=>{const row=document.createElement('div');row.className='owner-control-row';const copy=document.createElement('div');const title=document.createElement('b');title.textContent=ownerText(rule.rule_code);const meta=document.createElement('small');meta.textContent=ownerText(rule.candidate_count,0)+' candidat(s) · '+ownerText(rule.risk_level);copy.append(title,meta);const state=document.createElement('span');state.className='pill '+(rule.rule_enabled?'ok':'info');state.textContent=rule.rule_enabled?'Active':'Désactivée';row.append(copy,state);automationRoot.appendChild(row)});\n }\n const policy=snapshot.communication_policy||{};\n ownerRenderDefinition('#ownerPolicySummary',[\n ['Sortant',policy.outbound_enabled?'Activé':'Coupé'],\n ['SMS',policy.sms_sender_configured?'Configuré':'Expéditeur manquant'],\n ['Appels',policy.voice_caller_configured?'Configurés':'Émission coupée'],\n ['Jours fériés',policy.holiday_calendar_ready?'Prêts':'Calendrier manquant'],\n ['Version',ownerText(policy.policy_version,'—')]\n ]);\n const calendars=Array.isArray(snapshot.calendar_connections)?snapshot.calendar_connections:[];\n const calendar=calendars[0]||{};\n ownerRenderDefinition('#ownerCalendarSummary',[\n ['Compte',ownerText(calendar.account_email,'Aucun')],\n ['État',ownerText(calendar.status,'Non configuré')],\n ['Synchronisation',ownerText(calendar.sync_direction,'none')],\n ['Lecture',calendar.read_verified?'Vérifiée':'Non vérifiée'],\n ['Écriture',calendar.write_verified?'Vérifiée':'Interdite']\n ]);\n ownerRenderDelivery(snapshot.delivery||{});\n}\nfunction ownerRenderActivation(activation){\n const steps=activation&&activation.steps||{};\n const definitions=[\n ['holiday_calendar','Jours fériés','Règles françaises 2026–2027'],\n ['owner_identity','Identité dirigeant','Connexion personnelle et droits'],\n ['google_calendar','Google Calendar','Lecture, écriture et conflits'],\n ['sms_sender','Expéditeur SMS','Numéro Twilio compatible'],\n ['email_sender','Expéditeur e-mail','Compte Gmail vérifié'],\n ['communication_policy','Politique d’envoi','Validation humaine obligatoire'],\n ['outbox','Worker d’envoi','Effets externes désactivés']\n ];\n const root=q('#ownerActivationSteps');\n let completed=0;\n if(root){\n root.replaceChildren();\n definitions.forEach(item=>{\n const key=item[0],step=steps[key]||{},ready=Boolean(step.ready);\n if(ready)completed++;\n const row=document.createElement('div');row.className='owner-activation-step';\n const copy=document.createElement('div');\n const title=document.createElement('b');title.textContent=item[1];\n const meta=document.createElement('small');\n if(key==='holiday_calendar'&&step.details)meta.textContent='Couverture jusqu’au '+ownerText(step.details.coverage_through,'—');\n else if(key==='google_calendar'&&step.details)meta.textContent=Array.isArray(step.details.blockers)&&step.details.blockers.length?'Connexion ou vérification requise':'Synchronisation prête';\n else if(key==='owner_identity')meta.textContent=step.auth_linked?'Compte lié, validation récente requise':'Compte personnel à lier';\n else meta.textContent=item[2];\n copy.append(title,meta);\n const pill=document.createElement('span');\n pill.className='pill '+(ready?'ok':step.status==='human_approval_required'?'warn':'info');\n pill.textContent=ready?'Prêt':step.status==='human_approval_required'?'À valider':'À faire';\n row.append(copy,pill);root.appendChild(row);\n });\n }\n const total=definitions.length;\n ownerSetText('#ownerActivationProgress',completed+'/'+total+' prêts');\n const state=q('#ownerActivationState');\n if(state){\n const ready=activation.safe_state==='ready_for_human_activation';\n state.className='pill '+(ready?'ok':'warn');\n state.textContent=ready?'Prêt à valider':'Verrouillé en sécurité';\n }\n const next=q('#ownerActivationNext');\n if(next){\n next.replaceChildren();\n const actions=Array.isArray(activation.next_actions)?activation.next_actions:[];\n if(!actions.length){\n const done=document.createElement('div');done.className='owner-blocker ok';done.textContent='Tous les prérequis sont réunis. Une validation humaine reste nécessaire.';next.appendChild(done);\n }else{\n actions.forEach((action,index)=>{\n const row=document.createElement('div');row.className='owner-next-item';\n const badge=document.createElement('span');badge.className='owner-next-index';badge.textContent=String(index+1);\n const label=document.createElement('span');label.textContent=ownerText(action.label,action.key);\n row.append(badge,label);next.appendChild(row);\n });\n }\n }\n}\nfunction ownerSummarize(action,result){\n const data=result&&result.data||{};\n if(action==='get_autonomy_status'){\n const counts=data.counts||{};\n return 'Validations : '+ownerText(counts.pending_approvals,0)+' · règles actives : '+ownerText(counts.enabled_automation_rules,0)+' · outbox : '+ownerText(counts.pending_outbox,0);\n }\n if(action==='get_delivery_status'){\n const counts=data.counts||{};\n return 'SMS en attente : '+ownerText(counts.waiting,0)+' · envoyés : '+ownerText(counts.sent,0)+' · livrés : '+ownerText(counts.delivered,0)+' · échecs : '+ownerText(counts.failed,0);\n }\n if(action==='get_activation_readiness'){\n const steps=data.steps||{},values=Object.values(steps),ready=values.filter(step=>step&&step.ready).length;\n return ready+'/'+values.length+' prérequis prêts · '+(Array.isArray(data.next_actions)?data.next_actions.length:0)+' action(s) restante(s) · zéro exécution n8n';\n }\n if(action==='owner_daily_briefing'){\n const parts=[\n ['rendez-vous',data.appointments],\n ['urgences',data.urgent_requests],\n ['tâches en retard',data.overdue_tasks],\n ['validations',data.pending_approvals],\n ['devis à suivre',data.quotes_to_follow_up],\n ['factures échues',data.overdue_invoices]\n ].map(x=>x[0]+' : '+(Array.isArray(x[1])?x[1].length:0));\n return parts.join(' · ');\n }\n if(Array.isArray(data))return data.length+' résultat(s).';\n return result.assistant_message||'Résultat prêt.';\n}\nqa('[data-owner-action]').forEach(button=>{\n button.onclick=async()=>{\n const action=button.dataset.ownerAction;\n button.disabled=true;\n ownerSetText('#ownerCommandResult','Exécution…');\n try{\n const result=await ownerAction(action,{limit:10,status:'all',minimum_days_overdue:0});\n if(action==='get_autonomy_status')ownerRenderAutonomy(result.data||{});\n if(action==='get_delivery_status')ownerRenderDelivery(result.data||{});\n if(action==='get_activation_readiness'){ownerRenderActivation(result.data||{});ownerState.activationLoaded=true}\n ownerSetText('#ownerCommandResult',ownerSummarize(action,result));\n toast(result.assistant_message||'Résultat propriétaire prêt');\n }catch(error){\n ownerSetText('#ownerCommandResult',ownerText(error.message));\n toast(ownerText(error.message),false);\n }finally{button.disabled=!(ownerState.caps&&ownerState.caps.enabled)}\n };\n});\nfunction ownerStopVoice(message){\n if(ownerState.channel)try{ownerState.channel.close()}catch{}\n if(ownerState.pc)try{ownerState.pc.close()}catch{}\n if(ownerState.stream)ownerState.stream.getTracks().forEach(track=>track.stop());\n if(ownerState.audio)ownerState.audio.remove();\n ownerState.channel=null;ownerState.pc=null;ownerState.stream=null;ownerState.audio=null;ownerState.toolCalls.clear();\n const orb=q('#ownerOrb');if(orb)orb.classList.remove('live');\n const start=q('#ownerVoiceStart');if(start){start.disabled=!(ownerState.caps&&ownerState.caps.voice_available);start.textContent='Parler à l’assistante'}\n const stop=q('#ownerVoiceStop');if(stop)stop.disabled=true;\n if(message)ownerSetTranscript(message,true);\n}\nasync function ownerHandleTool(event){\n const callId=ownerText(event.call_id);\n const name=ownerText(event.name);\n if(!callId||!name||ownerState.toolCalls.has(callId))return;\n ownerState.toolCalls.add(callId);\n let args={};\n try{args=event.arguments?JSON.parse(event.arguments):{}}catch{args={}}\n let output;\n try{output=await ownerAction(name,args)}catch(error){output={ok:false,action_completed:false,execution_state:'failed',error:ownerText(error.message)}}\n if(ownerState.channel&&ownerState.channel.readyState==='open'){\n ownerState.channel.send(JSON.stringify({type:'conversation.item.create',item:{type:'function_call_output',call_id:callId,output:JSON.stringify(output)}}));\n ownerState.channel.send(JSON.stringify({type:'response.create'}));\n }\n}\nfunction ownerHandleRealtime(raw){\n let event;try{event=JSON.parse(raw)}catch{return}\n if(event.type==='response.function_call_arguments.done')ownerHandleTool(event);\n const delta=event.delta;\n if(typeof delta==='string'&&['response.audio_transcript.delta','response.output_audio_transcript.delta','response.output_text.delta'].includes(event.type))ownerSetTranscript(delta,true);\n if(event.type==='error')ownerSetTranscript('\\nErreur de session vocale. ',true);\n}\nasync function ownerStartVoice(){\n if(!ownerState.caps||!ownerState.caps.voice_available)return;\n const start=q('#ownerVoiceStart');if(start){start.disabled=true;start.textContent='Connexion…'}\n try{\n ownerState.stream=await navigator.mediaDevices.getUserMedia({audio:{echoCancellation:true,noiseSuppression:true},video:false});\n ownerState.pc=new RTCPeerConnection();\n ownerState.audio=document.createElement('audio');ownerState.audio.autoplay=true;ownerState.audio.hidden=true;document.body.appendChild(ownerState.audio);\n ownerState.pc.ontrack=event=>{ownerState.audio.srcObject=event.streams[0]};\n ownerState.channel=ownerState.pc.createDataChannel('oai-events');\n ownerState.channel.onmessage=event=>ownerHandleRealtime(event.data);\n ownerState.channel.onopen=()=>{\n const orb=q('#ownerOrb');if(orb)orb.classList.add('live');\n if(start)start.textContent='Assistante connectée';\n const stop=q('#ownerVoiceStop');if(stop)stop.disabled=false;\n ownerSetTranscript('Session connectée. Vous pouvez parler.\\n',false);\n };\n ownerState.channel.onclose=()=>ownerStopVoice('\\nSession terminée.');\n ownerState.stream.getTracks().forEach(track=>ownerState.pc.addTrack(track,ownerState.stream));\n const offer=await ownerState.pc.createOffer();\n await ownerState.pc.setLocalDescription(offer);\n const token=await ownerAuthToken();\n const response=await fetch('/api/owner/session',{\n method:'POST',\n headers:{'content-type':'application/sdp','x-csrf-token':csrf,...(token?{'x-owner-access-token':token}:{})},\n body:offer.sdp\n });\n if(!response.ok){\n let message='session_vocale_refusee';\n try{const failure=await response.json();message=failure.error||message}catch{}\n throw new Error(message);\n }\n const answer=await response.text();\n await ownerState.pc.setRemoteDescription({type:'answer',sdp:answer});\n }catch(error){\n ownerStopVoice('\\nConnexion impossible : '+ownerText(error.message));\n toast('Mode vocal indisponible',false);\n }\n}\nconst ownerStart=q('#ownerVoiceStart');if(ownerStart)ownerStart.onclick=ownerStartVoice;\nconst ownerStop=q('#ownerVoiceStop');if(ownerStop){ownerStop.disabled=true;ownerStop.onclick=()=>ownerStopVoice('\\nSession arrêtée.')}\nconst ownerAuthRequest=q('#ownerAuthRequest');if(ownerAuthRequest)ownerAuthRequest.onclick=ownerRequestMagicLink;\nconst ownerAuthLogout=q('#ownerAuthLogout');if(ownerAuthLogout)ownerAuthLogout.onclick=ownerLogoutStrongIdentity;\nconst ownerNav=q('.nav button[data-view=\"owner\"]');if(ownerNav)ownerNav.addEventListener('click',ownerFetchCaps);\nwindow.addEventListener('beforeunload',()=>ownerStopVoice(''));\nconst ownerAuthCallback=sessionStorage.getItem('piscine_owner_auth_callback_v1')==='1';\nif(ownerAuthCallback){\n sessionStorage.removeItem('piscine_owner_auth_callback_v1');\n showView('owner');\n if(location.hash!=='#owner')history.replaceState(null,'',location.pathname+(location.search||'')+'#owner');\n toast(ownerAuthLoad()?'Identité reçue, vérification en cours…':'Lien de connexion refusé',Boolean(ownerAuthLoad()));\n}\nif(ownerAuthCallback||location.hash==='#owner')void ownerFetchCaps();\n`;\n",[],[448,544],"800ae16d-7dd9-40cf-a4bc-c1d16cf61e3e","owner-runtime.ts","019f66f6-e506-776c-9df7-7cf6d60217f2",14,["D",1784139349011],8,"import { buildOwnerSessionConfig } from \"./owner-agent.ts\";\nimport { callOwnerTool, ownerBridgeStatus } from \"./owner-bridge.ts\";\nimport type { OwnerAuthStatus } from \"./owner-auth.ts\";\n\nconst OPENAI_API_KEY = Deno.env.get(\"OPENAI_API_KEY\") || \"\";\nconst OPENAI_PROJECT_ID = Deno.env.get(\"PISCINE_OPENAI_PROJECT_ID\") || \"\";\nconst MODEL = Deno.env.get(\"PISCINE_REALTIME_MODEL\") || \"gpt-realtime-2.1\";\nconst VOICE = Deno.env.get(\"PISCINE_REALTIME_VOICE_V3\")\n || Deno.env.get(\"PISCINE_REALTIME_VOICE_V2\")\n || Deno.env.get(\"PISCINE_REALTIME_VOICE\")\n || \"marin\";\nconst STAFF_ID = Deno.env.get(\"PISCINE_OWNER_STAFF_ID\") || \"\";\n\nexport const OWNER_COCKPIT_ACTIONS = new Set([\n \"owner_daily_briefing\",\n \"get_autonomy_status\",\n \"get_delivery_status\",\n \"get_activation_readiness\",\n \"list_priority_tasks\",\n \"find_client\",\n \"get_client_timeline\",\n \"list_pending_quotes\",\n \"list_overdue_invoices\",\n \"create_task\",\n \"prepare_approval\",\n \"complete_owner_session\",\n]);\n\nconst READ_ACTIONS = new Set([\n \"owner_daily_briefing\",\n \"get_autonomy_status\",\n \"get_delivery_status\",\n \"get_activation_readiness\",\n \"list_priority_tasks\",\n \"find_client\",\n \"get_client_timeline\",\n \"list_pending_quotes\",\n \"list_overdue_invoices\",\n]);\n\nfunction unique(values: string[]): string[] {\n return [...new Set(values)];\n}\n\nexport function ownerCapabilities(auth: OwnerAuthStatus) {\n const bridge = ownerBridgeStatus();\n const consoleBlockers: string[] = [];\n if (!bridge.enabled) consoleBlockers.push(\"owner_direct_gateway_disabled\");\n if (!bridge.configured) consoleBlockers.push(\"owner_direct_gateway_not_configured\");\n\n const voiceBlockers: string[] = [];\n if (!bridge.voice_gate_enabled) voiceBlockers.push(\"owner_voice_mode_disabled\");\n if (!OPENAI_API_KEY) voiceBlockers.push(\"openai_api_not_configured\");\n if (!STAFF_ID) voiceBlockers.push(\"owner_staff_identity_missing\");\n if (!auth.verified) {\n voiceBlockers.push(\"owner_strong_identity_required_for_voice\");\n }\n\n const commitBlockers = [\n ...(!auth.verified ? [\"owner_strong_identity_required_for_commit\"] : []),\n \"owner_commit_permission_disabled\",\n ];\n const consoleAvailable = bridge.available;\n const voiceAvailable = consoleAvailable\n && bridge.voice_gate_enabled\n && Boolean(OPENAI_API_KEY)\n && Boolean(STAFF_ID)\n && auth.verified;\n\n return {\n ok: true,\n schema_version: \"4.0\",\n enabled: consoleAvailable,\n configured: bridge.configured,\n console_available: consoleAvailable,\n voice_available: voiceAvailable,\n gateway_mode: bridge.gateway_mode,\n gateway_transport: bridge.gateway_transport,\n gateway_published: bridge.published,\n direct_gateway_enabled: bridge.enabled,\n commit_available: false,\n identity_configured: Boolean(STAFF_ID) && auth.configured,\n strong_identity_verified: auth.verified,\n owner_auth: {\n configured: auth.configured,\n verified: auth.verified,\n email_hint: auth.email_hint,\n provider: auth.provider,\n error: auth.error || null,\n },\n model: MODEL,\n voice: VOICE,\n blockers: unique([...consoleBlockers, ...voiceBlockers, ...commitBlockers]),\n console_blockers: consoleBlockers,\n voice_blockers: voiceBlockers,\n commit_blockers: commitBlockers,\n n8n_execution_used: false,\n safeguards: {\n reads: \"direct_supabase\",\n writes: \"preview_only\",\n approvals: \"prepare_only\",\n external_delivery: \"disabled\",\n strong_identity: \"required_for_commit\",\n idempotency: true,\n audit_receipts: true,\n n8n_execution_consumed: false,\n },\n actions: [...OWNER_COCKPIT_ACTIONS].map((key) => ({\n key,\n kind: READ_ACTIONS.has(key) ? \"read\" : \"write\",\n available: consoleAvailable,\n execution: READ_ACTIONS.has(key) ? \"read_only\" : \"preview_only\",\n gateway: \"direct_supabase\",\n n8n_execution_used: false,\n })),\n };\n}\n\nexport async function executeOwnerCockpitAction(\n action: string,\n data: Record,\n sessionNonce: string,\n accessToken = \"\",\n) {\n if (!OWNER_COCKPIT_ACTIONS.has(action)) {\n return {\n ok: false,\n action_completed: false,\n execution_state: \"failed\",\n error: \"owner_action_not_allowed\",\n safe_to_announce: false,\n gateway_mode: \"direct_supabase\",\n n8n_execution_used: false,\n };\n }\n\n return callOwnerTool(action, data, {\n id: STAFF_ID,\n role: \"owner\",\n correlation_id: `cockpit-owner-${sessionNonce}`,\n }, accessToken);\n}\n\nexport async function createOwnerRealtimeCall(\n sdp: string,\n sessionNonce: string,\n auth: OwnerAuthStatus,\n): Promise<{ ok: boolean; status: number; sdp?: string; error?: string }> {\n const capabilities = ownerCapabilities(auth);\n if (!capabilities.voice_available) {\n const blocker = capabilities.voice_blockers[0]\n || capabilities.console_blockers[0]\n || \"owner_voice_unavailable\";\n return { ok: false, status: 409, error: blocker };\n }\n if (!sdp.startsWith(\"v=0\") || sdp.length > 64_000) {\n return { ok: false, status: 400, error: \"invalid_sdp_offer\" };\n }\n\n const session = buildOwnerSessionConfig(MODEL, VOICE, {\n channel: \"cockpit_webrtc\",\n actor_type: \"staff\",\n actor_id: STAFF_ID,\n role: \"owner\",\n gateway_mode: \"direct_supabase\",\n console_available: capabilities.console_available,\n commit_available: false,\n n8n_execution_used: false,\n correlation_id: `cockpit-owner-${sessionNonce}`,\n });\n const form = new FormData();\n form.set(\"sdp\", sdp);\n form.set(\"session\", JSON.stringify(session));\n\n const headers: Record = {\n Authorization: `Bearer ${OPENAI_API_KEY}`,\n };\n if (OPENAI_PROJECT_ID) headers[\"OpenAI-Project\"] = OPENAI_PROJECT_ID;\n\n const response = await fetch(\"https://api.openai.com/v1/realtime/calls\", {\n method: \"POST\",\n headers,\n body: form,\n signal: AbortSignal.timeout(15_000),\n });\n const answer = (await response.text()).slice(0, 100_000);\n if (!response.ok) {\n return { ok: false, status: 502, error: \"openai_realtime_session_failed\" };\n }\n if (!answer.startsWith(\"v=0\")) {\n return { ok: false, status: 502, error: \"invalid_openai_sdp_answer\" };\n }\n return { ok: true, status: 200, sdp: answer };\n}\n",[],[448,553],"ebebe436-f332-404e-b78d-d3292e985d17","owner-bridge.ts","019f66f6-e506-776c-9df7-7931d42b971e",6,["D",1784139313820],4,"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nconst SUPABASE_URL = (Deno.env.get(\"PISCINE_OWNER_SUPABASE_URL\") || \"\").replace(/\\/$/, \"\");\nconst SUPABASE_PUBLISHABLE_KEY = Deno.env.get(\"PISCINE_OWNER_SUPABASE_PUBLISHABLE_KEY\") || \"\";\nconst DIRECT_SECRET = Deno.env.get(\"PISCINE_OWNER_DIRECT_SECRET\") || \"\";\nconst DIRECT_ENABLED = Deno.env.get(\"PISCINE_OWNER_DIRECT_ENABLED\") === \"true\";\nconst OWNER_MODE_ENABLED = Deno.env.get(\"PISCINE_OWNER_MODE_ENABLED\") === \"true\";\nconst STAFF_ID = Deno.env.get(\"PISCINE_OWNER_STAFF_ID\") || \"\";\n\nconst OWNER_ACTIONS = new Set([\n \"owner_daily_briefing\",\n \"get_autonomy_status\",\n \"get_delivery_status\",\n \"get_activation_readiness\",\n \"list_priority_tasks\",\n \"find_client\",\n \"get_client_timeline\",\n \"list_pending_quotes\",\n \"list_overdue_invoices\",\n \"create_task\",\n \"prepare_approval\",\n \"complete_owner_session\",\n]);\n\nconst OWNER_READ_CACHE_TTL: Record = {\n owner_daily_briefing: 300,\n get_autonomy_status: 180,\n get_delivery_status: 120,\n get_activation_readiness: 120,\n list_priority_tasks: 120,\n find_client: 120,\n get_client_timeline: 120,\n list_pending_quotes: 120,\n list_overdue_invoices: 120,\n};\n\nfunction clean(value: unknown, max = 4000): string {\n return String(value ?? \"\").trim().slice(0, max);\n}\n\nfunction cacheKey(action: string, args: Record): string {\n return action + \":\" + JSON.stringify(args);\n}\n\nasync function ensureReadCache(): Promise {\n await sqlite.execute(`create table if not exists owner_direct_read_cache (\n cache_key text primary key,\n payload_json text not null,\n expires_at integer not null,\n updated_at text not null\n )`);\n}\n\nasync function readOwnerCache(\n action: string,\n args: Record,\n): Promise | null> {\n const ttl = OWNER_READ_CACHE_TTL[action] || 0;\n if (!ttl) return null;\n await ensureReadCache();\n const result = await sqlite.execute({\n sql: `select payload_json from owner_direct_read_cache\n where cache_key=:cache_key and expires_at>unixepoch() limit 1`,\n args: { cache_key: cacheKey(action, args) },\n });\n if (!result.rows.length) return null;\n try {\n return JSON.parse(String((result.rows[0] as Record).payload_json || \"{}\"));\n } catch {\n return null;\n }\n}\n\nasync function writeOwnerCache(\n action: string,\n args: Record,\n payload: Record,\n): Promise {\n const ttl = OWNER_READ_CACHE_TTL[action] || 0;\n if (!ttl) return;\n await ensureReadCache();\n await sqlite.execute({\n sql: `insert into owner_direct_read_cache (\n cache_key,payload_json,expires_at,updated_at\n ) values (\n :cache_key,:payload_json,unixepoch()+:ttl,datetime('now')\n )\n on conflict(cache_key) do update set\n payload_json=excluded.payload_json,\n expires_at=excluded.expires_at,\n updated_at=excluded.updated_at`,\n args: {\n cache_key: cacheKey(action, args),\n payload_json: JSON.stringify(payload).slice(0, 100_000),\n ttl,\n },\n });\n}\n\nexport function ownerBridgeStatus() {\n const configured = Boolean(\n SUPABASE_URL\n && SUPABASE_PUBLISHABLE_KEY\n && DIRECT_SECRET\n && STAFF_ID,\n );\n const available = DIRECT_ENABLED && configured;\n return {\n enabled: DIRECT_ENABLED,\n configured,\n published: DIRECT_ENABLED,\n available,\n console_available: available,\n voice_gate_enabled: OWNER_MODE_ENABLED,\n gateway_mode: \"direct_supabase\" as const,\n gateway_transport: \"edge_function\" as const,\n n8n_execution_used: false,\n n8n_budget_enforced: false,\n read_cache_enabled: true,\n };\n}\n\nexport function ownerBridgeConfigured(): boolean {\n return ownerBridgeStatus().available;\n}\n\nexport async function callOwnerTool(\n action: string,\n args: Record,\n actor: Record,\n accessToken = \"\",\n): Promise> {\n if (!DIRECT_ENABLED) {\n return {\n ok: false,\n action_completed: false,\n execution_state: \"failed\",\n error: \"owner_direct_gateway_disabled\",\n safe_to_announce: true,\n assistant_message: \"La console propriétaire directe n’est pas activée.\",\n gateway_mode: \"direct_supabase\",\n n8n_execution_used: false,\n };\n }\n if (!OWNER_ACTIONS.has(action)) {\n return {\n ok: false,\n action_completed: false,\n execution_state: \"failed\",\n error: \"owner_action_not_allowed\",\n gateway_mode: \"direct_supabase\",\n n8n_execution_used: false,\n };\n }\n if (!SUPABASE_URL || !SUPABASE_PUBLISHABLE_KEY || !DIRECT_SECRET || !STAFF_ID) {\n return {\n ok: false,\n action_completed: false,\n execution_state: \"failed\",\n error: \"owner_direct_gateway_not_configured\",\n gateway_mode: \"direct_supabase\",\n n8n_execution_used: false,\n };\n }\n\n const strongAccessToken = clean(accessToken, 8192);\n const cached = strongAccessToken ? null : await readOwnerCache(action, args);\n if (cached) {\n return {\n ...cached,\n cache_hit: true,\n gateway_mode: \"direct_supabase\",\n gateway_transport: \"edge_function\",\n n8n_execution_used: false,\n };\n }\n\n const requestId = crypto.randomUUID();\n const correlationId = clean(actor.correlation_id || requestId, 180) || requestId;\n let response: Response;\n try {\n response = await fetch(`${SUPABASE_URL}/functions/v1/owner-direct-gateway`, {\n method: \"POST\",\n headers: {\n \"content-type\": \"application/json\",\n accept: \"application/json\",\n apikey: SUPABASE_PUBLISHABLE_KEY,\n Authorization: `Bearer ${strongAccessToken || SUPABASE_PUBLISHABLE_KEY}`,\n \"x-piscine-owner-secret\": DIRECT_SECRET,\n \"x-piscine-owner-staff-id\": STAFF_ID,\n \"x-request-id\": requestId,\n \"x-correlation-id\": correlationId,\n },\n body: JSON.stringify({\n p_action: action,\n p_data: args,\n }),\n signal: AbortSignal.timeout(8000),\n });\n } catch {\n return {\n ok: false,\n action_completed: false,\n execution_state: \"failed\",\n error: \"owner_direct_gateway_unreachable\",\n safe_to_announce: true,\n assistant_message: \"La console propriétaire est temporairement indisponible.\",\n gateway_mode: \"direct_supabase\",\n n8n_execution_used: false,\n };\n }\n\n const raw = (await response.text()).slice(0, 100_000);\n let payload: Record;\n try {\n const parsed = JSON.parse(raw);\n payload = parsed && typeof parsed === \"object\" && !Array.isArray(parsed)\n ? parsed as Record\n : { ok: false, action_completed: false, error: \"owner_direct_gateway_invalid_response\" };\n } catch {\n payload = {\n ok: false,\n action_completed: false,\n error: \"owner_direct_gateway_invalid_response\",\n };\n }\n\n const normalized = {\n ...payload,\n gateway_mode: \"direct_supabase\",\n gateway_transport: \"edge_function\",\n n8n_execution_used: false,\n };\n if (!response.ok) {\n return {\n ...normalized,\n ok: false,\n action_completed: false,\n execution_state: \"failed\",\n http_status: response.status,\n };\n }\n if (payload.ok !== false && !strongAccessToken) {\n await writeOwnerCache(action, args, normalized);\n }\n return normalized;\n}\n",[],[448,562],"3d6c1666-2962-47d3-b9a4-ee72fccd9f3c","owner-auth.ts","1489cb0e-8079-11f1-ba29-1607ee4eb77e",34,["D",1784139604504],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nconst SUPABASE_URL = (\n Deno.env.get(\"PISCINE_OWNER_SUPABASE_URL\") || \"\"\n).replace(/\\/$/, \"\");\nconst PUBLISHABLE_KEY =\n Deno.env.get(\"PISCINE_OWNER_SUPABASE_PUBLISHABLE_KEY\") || \"\";\nconst OWNER_EMAIL = (\n Deno.env.get(\"PISCINE_OWNER_EMAIL\") || \"\"\n).trim().toLowerCase();\n\nconst RATE_TABLE = \"owner_email_auth_rate\";\nconst MIN_REQUEST_INTERVAL_SECONDS = 60;\nconst REQUEST_WINDOW_SECONDS = 60 * 60;\nconst MAX_REQUESTS_PER_WINDOW = 5;\nlet rateTableInit: Promise | null = null;\n\nexport type OwnerAuthStatus = {\n configured: boolean;\n verified: boolean;\n email_hint: string;\n provider: \"supabase_email\";\n error?: string;\n};\n\ntype TokenPayload = {\n access_token: string;\n refresh_token: string;\n expires_in: number;\n token_type: \"bearer\";\n};\n\nfunction emailHint(email: string): string {\n const [local, domain] = email.split(\"@\");\n if (!local || !domain) return \"\";\n return `${local.slice(0, 1)}••••@${domain}`;\n}\n\nfunction cleanToken(value: unknown): string {\n const token = String(value || \"\").trim();\n if (\n token.length < 20\n || token.length > 8192\n || /\\s/.test(token)\n ) return \"\";\n return token;\n}\n\nasync function ensureRateTable(): Promise {\n if (!rateTableInit) {\n rateTableInit = (async () => {\n await sqlite.execute(`create table if not exists ${RATE_TABLE} (\n scope text primary key,\n request_count integer not null default 0,\n window_started_at integer not null,\n last_requested_at integer not null\n )`);\n })().catch((error) => {\n rateTableInit = null;\n throw error;\n });\n }\n return rateTableInit!;\n}\n\nasync function consumeMagicLinkQuota(): Promise {\n await ensureRateTable();\n const now = Math.floor(Date.now() / 1000);\n const result = await sqlite.execute({\n sql: `select request_count,window_started_at,last_requested_at\n from ${RATE_TABLE}\n where scope='owner_magic_link'\n limit 1`,\n args: [],\n });\n const row = result.rows[0] as Record | undefined;\n const previousCount = Number(row?.request_count || 0);\n const previousWindow = Number(row?.window_started_at || now);\n const previousRequest = Number(row?.last_requested_at || 0);\n const windowExpired = now - previousWindow >= REQUEST_WINDOW_SECONDS;\n const count = windowExpired ? 0 : previousCount;\n const windowStartedAt = windowExpired ? now : previousWindow;\n\n if (previousRequest && now - previousRequest < MIN_REQUEST_INTERVAL_SECONDS) {\n return MIN_REQUEST_INTERVAL_SECONDS - (now - previousRequest);\n }\n if (count >= MAX_REQUESTS_PER_WINDOW) {\n return Math.max(1, REQUEST_WINDOW_SECONDS - (now - windowStartedAt));\n }\n\n await sqlite.execute({\n sql: `insert into ${RATE_TABLE} (\n scope,request_count,window_started_at,last_requested_at\n ) values (\n 'owner_magic_link',:request_count,:window_started_at,:last_requested_at\n )\n on conflict(scope) do update set\n request_count=excluded.request_count,\n window_started_at=excluded.window_started_at,\n last_requested_at=excluded.last_requested_at`,\n args: {\n request_count: count + 1,\n window_started_at: windowStartedAt,\n last_requested_at: now,\n },\n });\n return 0;\n}\n\nfunction configured(): boolean {\n return Boolean(SUPABASE_URL && PUBLISHABLE_KEY && OWNER_EMAIL);\n}\n\nfunction safeRedirectOrigin(origin: string): string {\n try {\n const parsed = new URL(origin);\n const allowedHost = parsed.hostname.endsWith(\".web.val.run\")\n || parsed.hostname === \"localhost\";\n if (\n !allowedHost\n || (parsed.protocol !== \"https:\" && parsed.hostname !== \"localhost\")\n ) return \"\";\n return parsed.origin;\n } catch {\n return \"\";\n }\n}\n\nasync function parseResponse(response: Response): Promise> {\n const raw = (await response.text()).slice(0, 20_000);\n if (!raw) return {};\n try {\n const parsed = JSON.parse(raw);\n return parsed && typeof parsed === \"object\" && !Array.isArray(parsed)\n ? parsed as Record\n : {};\n } catch {\n return {};\n }\n}\n\nexport function ownerAccessToken(req: Request): string {\n return cleanToken(req.headers.get(\"x-owner-access-token\") || \"\");\n}\n\nexport function ownerAuthConfiguration(): OwnerAuthStatus {\n return {\n configured: configured(),\n verified: false,\n email_hint: emailHint(OWNER_EMAIL),\n provider: \"supabase_email\",\n };\n}\n\nexport async function requestOwnerMagicLink(\n requestOrigin: string,\n): Promise> {\n if (!configured()) {\n return {\n ok: false,\n error: \"owner_email_auth_not_configured\",\n http_status: 503,\n };\n }\n\n const origin = safeRedirectOrigin(requestOrigin);\n if (!origin) {\n return {\n ok: false,\n error: \"owner_auth_redirect_rejected\",\n http_status: 403,\n };\n }\n\n const retryAfter = await consumeMagicLinkQuota();\n if (retryAfter > 0) {\n return {\n ok: false,\n error: \"owner_auth_rate_limited\",\n http_status: 429,\n retry_after: retryAfter,\n };\n }\n\n const redirectTo = `${origin}/?owner_auth=callback`;\n let response: Response;\n try {\n response = await fetch(\n `${SUPABASE_URL}/auth/v1/otp?redirect_to=${\n encodeURIComponent(redirectTo)\n }`,\n {\n method: \"POST\",\n headers: {\n \"content-type\": \"application/json\",\n accept: \"application/json\",\n apikey: PUBLISHABLE_KEY,\n authorization: `Bearer ${PUBLISHABLE_KEY}`,\n },\n body: JSON.stringify({\n email: OWNER_EMAIL,\n create_user: true,\n }),\n signal: AbortSignal.timeout(8000),\n },\n );\n } catch {\n return {\n ok: false,\n error: \"owner_auth_service_unreachable\",\n http_status: 502,\n };\n }\n\n if (!response.ok) {\n const payload = await parseResponse(response);\n return {\n ok: false,\n error: response.status === 429\n ? \"owner_auth_rate_limited\"\n : \"owner_magic_link_request_failed\",\n http_status: response.status === 429 ? 429 : 502,\n provider_code: String(payload.error_code || \"\").slice(0, 80) || undefined,\n };\n }\n\n return {\n ok: true,\n delivery: \"email\",\n email_hint: emailHint(OWNER_EMAIL),\n expires_hint: \"Lien à usage unique\",\n n8n_execution_used: false,\n };\n}\n\nexport async function refreshOwnerSession(\n refreshToken: unknown,\n): Promise> {\n const token = cleanToken(refreshToken);\n if (!configured() || !token) {\n return {\n ok: false,\n error: \"owner_refresh_token_invalid\",\n http_status: 401,\n };\n }\n\n let response: Response;\n try {\n response = await fetch(\n `${SUPABASE_URL}/auth/v1/token?grant_type=refresh_token`,\n {\n method: \"POST\",\n headers: {\n \"content-type\": \"application/json\",\n accept: \"application/json\",\n apikey: PUBLISHABLE_KEY,\n authorization: `Bearer ${PUBLISHABLE_KEY}`,\n },\n body: JSON.stringify({ refresh_token: token }),\n signal: AbortSignal.timeout(7000),\n },\n );\n } catch {\n return {\n ok: false,\n error: \"owner_auth_service_unreachable\",\n http_status: 502,\n };\n }\n\n const payload = await parseResponse(response);\n if (!response.ok) {\n return {\n ok: false,\n error: \"owner_session_refresh_failed\",\n http_status: response.status === 401 || response.status === 400 ? 401 : 502,\n };\n }\n\n const accessToken = cleanToken(payload.access_token);\n const nextRefreshToken = cleanToken(payload.refresh_token);\n const expiresIn = Math.max(\n 60,\n Math.min(86_400, Number(payload.expires_in || 3600)),\n );\n if (!accessToken || !nextRefreshToken) {\n return {\n ok: false,\n error: \"owner_auth_invalid_response\",\n http_status: 502,\n };\n }\n\n const result: TokenPayload = {\n access_token: accessToken,\n refresh_token: nextRefreshToken,\n expires_in: expiresIn,\n token_type: \"bearer\",\n };\n return { ok: true, ...result };\n}\n\nexport async function verifyOwnerAccessToken(\n value: unknown,\n): Promise {\n const token = cleanToken(value);\n const base = ownerAuthConfiguration();\n if (!base.configured) {\n return { ...base, error: \"owner_email_auth_not_configured\" };\n }\n if (!token) return base;\n\n let response: Response;\n try {\n response = await fetch(`${SUPABASE_URL}/auth/v1/user`, {\n method: \"GET\",\n headers: {\n accept: \"application/json\",\n apikey: PUBLISHABLE_KEY,\n authorization: `Bearer ${token}`,\n },\n signal: AbortSignal.timeout(5000),\n });\n } catch {\n return { ...base, error: \"owner_auth_service_unreachable\" };\n }\n\n if (!response.ok) {\n return { ...base, error: \"owner_strong_identity_invalid\" };\n }\n const user = await parseResponse(response);\n const userEmail = String(user.email || \"\").trim().toLowerCase();\n const confirmed = Boolean(user.email_confirmed_at || user.confirmed_at);\n if (!confirmed || userEmail !== OWNER_EMAIL) {\n return { ...base, error: \"owner_email_not_allowlisted\" };\n }\n\n return {\n ...base,\n verified: true,\n };\n}\n\nexport async function revokeOwnerSession(\n value: unknown,\n): Promise> {\n const token = cleanToken(value);\n if (!configured() || !token) return { ok: true };\n\n try {\n const response = await fetch(`${SUPABASE_URL}/auth/v1/logout`, {\n method: \"POST\",\n headers: {\n apikey: PUBLISHABLE_KEY,\n authorization: `Bearer ${token}`,\n },\n signal: AbortSignal.timeout(5000),\n });\n return {\n ok: response.ok || response.status === 401,\n };\n } catch {\n return { ok: false, error: \"owner_logout_unreachable\" };\n }\n}\n",[],[448,571],"2b6f8a5a-7394-4c3b-9d65-7af32ea25f79","owner-agent.ts","019f66f6-e506-776c-9df7-7545c4829565",["D",1784138884418],"export const OWNER_ROLE_PROMPT = `\n# RÔLE\nTu es l’assistante personnelle du dirigeant de l’entreprise de piscine.\nCette session est réservée à un membre du personnel authentifié.\nTu aides à piloter l’activité sans jamais agir comme l’accueil téléphonique client.\n\n# OBJECTIF\nRéduire le travail administratif : briefing, recherche, tâches, préparation de décisions et suivi.\nDonne des réponses courtes, factuelles et immédiatement utiles.\n\n# VÉRITÉ OPÉRATIONNELLE\n- Utilise un outil pour toute information dépendant des données de l’entreprise.\n- Ne transforme jamais une proposition en action exécutée.\n- Ne dis jamais qu’une action est terminée sans execution_state terminal.\n- Distingue : proposé, en attente de validation, exécuté, livré et échoué.\n- Si une donnée manque, pose uniquement la prochaine question nécessaire.\n\n# AUTORISATIONS V1\nTu peux lire les priorités, le planning, les clients, les devis, les factures et les alertes.\nTu peux consulter le suivi des SMS et distinguer clairement : en attente, envoyé, livré et échec.\nTu peux créer une tâche après un résumé vocal clair.\nTu peux préparer une demande de validation pour une action sensible.\nTu ne peux pas envoyer de document, modifier une facture, marquer un paiement, supprimer une donnée\nou lancer une campagne sans validation dans le cockpit.\n\n# CONDUITE\n1. Comprends la demande.\n2. Lis le contexte utile.\n3. Réponds directement ou prépare une seule action.\n4. Pour une écriture autorisée, résume exactement ce qui sera créé.\n5. Pour une action sensible, crée une validation au lieu de l’exécuter.\n6. Termine par le résultat réel et la prochaine étape éventuelle.\n\n# STYLE\nFrançais naturel, professionnel, direct et chaleureux.\nUne ou deux phrases par tour sauf si une liste est explicitement demandée.\nNe prononce jamais le nom des outils, du JSON, des identifiants internes ou des messages techniques.\n`.trim();\n\ntype JsonSchema = Record;\n\nfunction tool(\n name: string,\n description: string,\n properties: Record = {},\n required: string[] = [],\n) {\n return {\n type: \"function\",\n name,\n description,\n parameters: {\n type: \"object\",\n additionalProperties: false,\n properties,\n required,\n },\n };\n}\n\nexport const OWNER_REALTIME_TOOLS = [\n tool(\"owner_daily_briefing\", \"Lire les rendez-vous, urgences, rappels, validations et alertes utiles du jour.\"),\n tool(\"get_autonomy_status\", \"Lire l’état des validations, automatisations, communications, calendriers et garde-fous.\"),\n tool(\"get_delivery_status\", \"Consulter en lecture seule les statuts de livraison SMS Twilio, les échecs et le plan du SMS de test.\"),\n tool(\"get_activation_readiness\", \"Lire les prérequis exacts avant d’activer Google Calendar, les canaux sortants ou les droits du dirigeant.\"),\n tool(\"list_priority_tasks\", \"Lister les tâches prioritaires ou en retard.\", {\n limit: { type: \"integer\", minimum: 1, maximum: 20 },\n status: { type: \"string\", enum: [\"open\", \"overdue\", \"all\"] },\n }),\n tool(\"find_client\", \"Rechercher un client par nom, téléphone, email ou adresse.\", {\n query: { type: \"string\", minLength: 2, maxLength: 180 },\n }, [\"query\"]),\n tool(\"get_client_timeline\", \"Lire la chronologie métier d’un client identifié.\", {\n client_id: { type: \"string\", minLength: 36, maxLength: 36 },\n limit: { type: \"integer\", minimum: 1, maximum: 50 },\n }, [\"client_id\"]),\n tool(\"list_pending_quotes\", \"Lister les devis à valider, envoyer, relancer ou convertir.\", {\n status: { type: \"string\", enum: [\"draft\", \"ready\", \"sent\", \"overdue\", \"all\"] },\n limit: { type: \"integer\", minimum: 1, maximum: 30 },\n }),\n tool(\"list_overdue_invoices\", \"Lister les factures arrivées à échéance sans paiement confirmé.\", {\n minimum_days_overdue: { type: \"integer\", minimum: 0, maximum: 365 },\n limit: { type: \"integer\", minimum: 1, maximum: 30 },\n }),\n tool(\"create_task\", \"Créer une tâche administrative après résumé explicite.\", {\n title: { type: \"string\", minLength: 3, maxLength: 180 },\n description: { type: \"string\", maxLength: 1200 },\n priority: { type: \"string\", enum: [\"low\", \"normal\", \"high\", \"urgent\"] },\n due_at: { type: [\"string\", \"null\"], description: \"Date ISO 8601 ou null.\" },\n client_id: { type: [\"string\", \"null\"] },\n demande_id: { type: [\"string\", \"null\"] },\n }, [\"title\", \"priority\"]),\n tool(\"prepare_approval\", \"Créer une demande de validation dans le cockpit sans exécuter l’action.\", {\n action_key: { type: \"string\", minLength: 3, maxLength: 120 },\n summary: { type: \"string\", minLength: 5, maxLength: 600 },\n proposed_payload: { type: \"object\", additionalProperties: true },\n }, [\"action_key\", \"summary\", \"proposed_payload\"]),\n tool(\"complete_owner_session\", \"Clôturer la session avec un résumé factuel.\", {\n summary: { type: \"string\", minLength: 3, maxLength: 1200 },\n outcome: { type: \"string\", enum: [\"completed\", \"partially_completed\", \"no_action\", \"failed\"] },\n }, [\"summary\", \"outcome\"]),\n];\n\nexport function buildOwnerInstructions(context: Record | null): string {\n if (!context) return OWNER_ROLE_PROMPT;\n return `${OWNER_ROLE_PROMPT}\n\n# CONTEXTE AUTHENTIFIÉ\n${JSON.stringify(context).slice(0, 8000)}`;\n}\n\nexport function buildOwnerSessionConfig(\n model: string,\n voice: string,\n context: Record | null,\n) {\n return {\n type: \"realtime\",\n model,\n reasoning: { effort: \"low\" },\n instructions: buildOwnerInstructions(context),\n audio: {\n input: {\n turn_detection: { type: \"semantic_vad\" },\n },\n output: { voice },\n },\n tools: OWNER_REALTIME_TOOLS,\n tool_choice: \"auto\",\n };\n}\n",[],[448,579],"78ce065c-ca42-42c6-b3fc-cca11f2228c5","n8n-budget.ts","019f66f6-e506-776c-9df7-710d01697a34",["D",1784138884418],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nexport type N8nBudgetCategory =\n | \"test\"\n | \"verification\"\n | \"production\"\n | \"callback_batch\";\n\nconst PROJECT_KEY = \"pisciniste\";\nconst TIMEZONE = \"Europe/Paris\";\nconst TEST_DAILY_LIMIT = 10;\nconst ACCOUNT_MONTHLY_LIMIT = 2500;\nconst PROJECT_DAILY_CEILING = 83;\nconst PRODUCTION_WARNING_THRESHOLD = 60;\nconst RECOVERY_DAILY_LIMIT = 8;\n\nfunction localDay(date = new Date()): string {\n const parts = new Intl.DateTimeFormat(\"en-CA\", {\n timeZone: TIMEZONE,\n year: \"numeric\",\n month: \"2-digit\",\n day: \"2-digit\",\n }).formatToParts(date);\n const values = Object.fromEntries(parts.map((part) => [part.type, part.value]));\n return [values.year, values.month, values.day].join(\"-\");\n}\n\nexport function secondsUntilNextMonthReset(date = new Date()): number {\n const [year, month] = localDay(date).split(\"-\").map(Number);\n const resetAtUtc = Date.UTC(year, month, 1, 2, 0, 0);\n return Math.max(3600, Math.ceil((resetAtUtc - date.getTime()) / 1000));\n}\n\nasync function ensureBudgetTables() {\n await sqlite.batch([\n `create table if not exists n8n_execution_budget_policy (\n project_key text primary key,\n timezone text not null,\n test_daily_limit integer not null,\n project_daily_ceiling integer not null,\n production_warning_threshold integer not null,\n verification_strategy text not null,\n micro_tests_forbidden integer not null,\n batch_required integer not null,\n policy_version text not null,\n updated_at text not null\n )`,\n `create table if not exists n8n_execution_budget_ledger (\n budget_day text not null,\n project_key text not null,\n category text not null,\n units integer not null,\n reservation_key text not null,\n metadata_json text not null default '{}',\n created_at text not null,\n primary key (budget_day, project_key, reservation_key)\n )`,\n `create table if not exists n8n_execution_circuit (\n project_key text primary key,\n state text not null default 'closed',\n reason text,\n opened_at text,\n open_until integer,\n updated_at text not null\n )`,\n {\n sql: `insert into n8n_execution_budget_policy (\n project_key,timezone,test_daily_limit,project_daily_ceiling,\n production_warning_threshold,verification_strategy,\n micro_tests_forbidden,batch_required,policy_version,updated_at\n ) values (\n :project_key,:timezone,:test_limit,:daily_ceiling,\n :warning_threshold,'static_first',1,1,:policy_version,datetime('now')\n )\n on conflict(project_key) do update set\n timezone=excluded.timezone,\n test_daily_limit=excluded.test_daily_limit,\n project_daily_ceiling=excluded.project_daily_ceiling,\n production_warning_threshold=excluded.production_warning_threshold,\n verification_strategy=excluded.verification_strategy,\n micro_tests_forbidden=excluded.micro_tests_forbidden,\n batch_required=excluded.batch_required,\n policy_version=excluded.policy_version,\n updated_at=datetime('now')`,\n args: {\n project_key: PROJECT_KEY,\n timezone: TIMEZONE,\n test_limit: TEST_DAILY_LIMIT,\n daily_ceiling: PROJECT_DAILY_CEILING,\n warning_threshold: PRODUCTION_WARNING_THRESHOLD,\n policy_version: \"2026-07-15-strict-v2\",\n },\n },\n ]);\n}\n\nexport async function n8nCircuitStatus() {\n await ensureBudgetTables();\n const result = await sqlite.execute({\n sql: `select state,reason,opened_at,open_until,updated_at\n from n8n_execution_circuit where project_key=:project_key limit 1`,\n args: { project_key: PROJECT_KEY },\n });\n const row = result.rows[0] as Record | undefined;\n const openUntil = Number(row?.open_until || 0);\n const open = row?.state === \"open\" && openUntil > Math.floor(Date.now() / 1000);\n return {\n open,\n state: open ? \"open\" : \"closed\",\n reason: open ? String(row?.reason || \"upstream_unavailable\") : null,\n opened_at: row?.opened_at || null,\n open_until: open ? new Date(openUntil * 1000).toISOString() : null,\n };\n}\n\nexport async function openN8nCircuit(reason: string, durationSeconds = 86400) {\n await ensureBudgetTables();\n const safeDuration = Math.max(900, Math.min(3456000, Number(durationSeconds) || 86400));\n await sqlite.execute({\n sql: `insert into n8n_execution_circuit (\n project_key,state,reason,opened_at,open_until,updated_at\n ) values (\n :project_key,'open',:reason,datetime('now'),unixepoch()+:duration,datetime('now')\n )\n on conflict(project_key) do update set\n state='open',reason=excluded.reason,opened_at=datetime('now'),\n open_until=excluded.open_until,updated_at=datetime('now')`,\n args: {\n project_key: PROJECT_KEY,\n reason: String(reason || \"upstream_unavailable\").slice(0, 240),\n duration: safeDuration,\n },\n });\n return n8nCircuitStatus();\n}\n\nexport async function closeN8nCircuit() {\n await ensureBudgetTables();\n await sqlite.execute({\n sql: `insert into n8n_execution_circuit (\n project_key,state,reason,opened_at,open_until,updated_at\n ) values (:project_key,'closed',null,null,null,datetime('now'))\n on conflict(project_key) do update set\n state='closed',reason=null,opened_at=null,open_until=null,updated_at=datetime('now')`,\n args: { project_key: PROJECT_KEY },\n });\n return n8nCircuitStatus();\n}\n\nexport async function n8nBudgetStatus() {\n await ensureBudgetTables();\n const day = localDay();\n const result = await sqlite.execute({\n sql: `select\n coalesce(sum(units) filter (where category in ('test','verification')),0) as test_used,\n coalesce(sum(units) filter (where category not in ('test','verification')),0) as production_used,\n coalesce(sum(units) filter (where category='callback_batch'),0) as recovery_used,\n coalesce(sum(units),0) as total_used\n from n8n_execution_budget_ledger\n where budget_day=:budget_day and project_key=:project_key`,\n args: { budget_day: day, project_key: PROJECT_KEY },\n });\n const row = result.rows[0] as Record | undefined;\n const testUsed = Number(row?.test_used || 0);\n const productionUsed = Number(row?.production_used || 0);\n const recoveryUsed = Number(row?.recovery_used || 0);\n const totalUsed = Number(row?.total_used || 0);\n const budgetMonth = day.slice(0, 7);\n const monthlyResult = await sqlite.execute({\n sql: `select coalesce(sum(units),0) as monthly_used\n from n8n_execution_budget_ledger\n where substr(budget_day,1,7)=:budget_month\n and project_key=:project_key`,\n args: { budget_month: budgetMonth, project_key: PROJECT_KEY },\n });\n const monthlyUsed = Number(\n (monthlyResult.rows[0] as Record | undefined)?.monthly_used || 0,\n );\n const circuit = await n8nCircuitStatus();\n return {\n circuit,\n ok: true,\n project_key: PROJECT_KEY,\n budget_day: day,\n timezone: TIMEZONE,\n policy_version: \"2026-07-15-strict-v2\",\n test_daily_limit: TEST_DAILY_LIMIT,\n account_monthly_limit: ACCOUNT_MONTHLY_LIMIT,\n budget_month: budgetMonth,\n monthly_used: monthlyUsed,\n monthly_remaining: Math.max(ACCOUNT_MONTHLY_LIMIT - monthlyUsed, 0),\n test_used: testUsed,\n test_remaining: Math.max(TEST_DAILY_LIMIT - testUsed, 0),\n production_used: productionUsed,\n recovery_daily_limit: RECOVERY_DAILY_LIMIT,\n recovery_used: recoveryUsed,\n recovery_remaining: Math.max(RECOVERY_DAILY_LIMIT - recoveryUsed, 0),\n total_used: totalUsed,\n project_daily_ceiling: PROJECT_DAILY_CEILING,\n project_remaining: Math.max(PROJECT_DAILY_CEILING - totalUsed, 0),\n production_warning_threshold: PRODUCTION_WARNING_THRESHOLD,\n warning: productionUsed >= PRODUCTION_WARNING_THRESHOLD,\n runtime_tests_allowed: testUsed < TEST_DAILY_LIMIT,\n verification_strategy: \"static_first\",\n micro_tests_forbidden: true,\n batch_required: true,\n };\n}\n\nexport async function reserveN8nExecution(\n category: N8nBudgetCategory,\n reservationKey: string,\n metadata: Record = {},\n units = 1,\n) {\n await ensureBudgetTables();\n const circuit = await n8nCircuitStatus();\n if (circuit.open) {\n return {\n ok: false,\n allowed: false,\n error: \"n8n_circuit_open\",\n circuit,\n };\n }\n const day = localDay();\n const budgetMonth = day.slice(0, 7);\n const safeKey = String(reservationKey || \"\").trim().slice(0, 240);\n const safeUnits = Math.max(1, Math.min(10, Number(units) || 1));\n if (!safeKey) {\n return { ok: false, allowed: false, error: \"n8n_budget_reservation_key_required\" };\n }\n\n const existing = await sqlite.execute({\n sql: `select category,units\n from n8n_execution_budget_ledger\n where budget_day=:budget_day\n and project_key=:project_key\n and reservation_key=:reservation_key\n limit 1`,\n args: {\n budget_day: day,\n project_key: PROJECT_KEY,\n reservation_key: safeKey,\n },\n });\n if (existing.rows.length) {\n return {\n ok: true,\n allowed: true,\n idempotent_replay: true,\n ...(await n8nBudgetStatus()),\n };\n }\n\n const isTest = category === \"test\" || category === \"verification\";\n const isRecovery = category === \"callback_batch\";\n await sqlite.execute({\n sql: `insert or ignore into n8n_execution_budget_ledger (\n budget_day,project_key,category,units,reservation_key,metadata_json,created_at\n )\n select\n :budget_day,:project_key,:category,:units,:reservation_key,:metadata_json,datetime('now')\n where\n (\n :is_test=0\n or coalesce((\n select sum(units)\n from n8n_execution_budget_ledger\n where budget_day=:budget_day\n and project_key=:project_key\n and category in ('test','verification')\n ),0)+:units<=:test_limit\n )\n and (\n :is_recovery=0\n or coalesce((\n select sum(units)\n from n8n_execution_budget_ledger\n where budget_day=:budget_day\n and project_key=:project_key\n and category='callback_batch'\n ),0)+:units<=:recovery_limit\n )\n and coalesce((\n select sum(units)\n from n8n_execution_budget_ledger\n where budget_day=:budget_day and project_key=:project_key\n ),0)+:units<=:daily_ceiling\n and coalesce((\n select sum(units)\n from n8n_execution_budget_ledger\n where substr(budget_day,1,7)=:budget_month\n and project_key=:project_key\n ),0)+:units<=:monthly_limit`,\n args: {\n budget_day: day,\n budget_month: budgetMonth,\n project_key: PROJECT_KEY,\n category,\n units: safeUnits,\n reservation_key: safeKey,\n metadata_json: JSON.stringify(metadata).slice(0, 4000),\n is_test: isTest ? 1 : 0,\n is_recovery: isRecovery ? 1 : 0,\n test_limit: TEST_DAILY_LIMIT,\n recovery_limit: RECOVERY_DAILY_LIMIT,\n daily_ceiling: PROJECT_DAILY_CEILING,\n monthly_limit: ACCOUNT_MONTHLY_LIMIT,\n },\n });\n\n const inserted = await sqlite.execute({\n sql: `select 1 as present\n from n8n_execution_budget_ledger\n where budget_day=:budget_day\n and project_key=:project_key\n and reservation_key=:reservation_key\n limit 1`,\n args: {\n budget_day: day,\n project_key: PROJECT_KEY,\n reservation_key: safeKey,\n },\n });\n const status = await n8nBudgetStatus();\n if (!inserted.rows.length) {\n return {\n ...status,\n ok: false,\n allowed: false,\n error: isTest\n ? \"n8n_test_daily_budget_exhausted\"\n : isRecovery && status.recovery_remaining < safeUnits\n ? \"n8n_recovery_daily_budget_exhausted\"\n : status.monthly_remaining < safeUnits\n ? \"n8n_account_monthly_budget_exhausted\"\n : \"n8n_project_daily_budget_exhausted\",\n };\n }\n return {\n ...status,\n ok: true,\n allowed: true,\n idempotent_replay: false,\n category,\n units: safeUnits,\n };\n}\n",[],[448,586],"d6333c95-a143-4059-80a4-5a09f1a76d07","documents.ts","019f66f6-e506-776c-9df7-6c8bc0f81af2",["D",1784138884418],"type AnyRecord = Record;\n\nconst esc = (value: unknown) => String(value ?? \"\").replace(/[&<>\"']/g, (c) => ({\n \"&\": \"&\", \"<\": \"<\", \">\": \">\", '\"': \""\", \"'\": \"'\",\n}[c] || c));\n\nconst money = (value: unknown) => new Intl.NumberFormat(\"fr-FR\", {\n style: \"currency\", currency: \"EUR\",\n}).format(Number(value || 0));\n\nconst dateFr = (value: unknown) => {\n if (!value) return \"—\";\n const d = new Date(String(value));\n return Number.isNaN(d.getTime()) ? \"—\" : new Intl.DateTimeFormat(\"fr-FR\", { dateStyle: \"long\" }).format(d);\n};\n\nfunction companyBlock(settings: AnyRecord) {\n const e = settings?.entreprise || {};\n return {\n name: e.nom || \"Votre entreprise de piscine\",\n address: e.adresse || \"Adresse à compléter\",\n phone: e.tel || \"\",\n email: e.email || \"\",\n siret: e.siret || \"\",\n iban: e.iban || \"\",\n quoteTerms: e.mentions_devis || \"Devis valable selon la durée indiquée. Travaux réalisés après acceptation et versement de l’acompte prévu.\",\n invoiceTerms: e.mentions_facture || \"Paiement à l’échéance indiquée. En cas de retard, des pénalités peuvent être exigibles selon la réglementation applicable.\",\n };\n}\n\nfunction clientBlock(client: AnyRecord) {\n return {\n name: client?.nom || \"Client\",\n address: [client?.adresse, [client?.code_postal, client?.ville].filter(Boolean).join(\" \")].filter(Boolean).join(\"
\"),\n phone: client?.telephone || \"\",\n email: client?.email || \"\",\n };\n}\n\nfunction lineRows(lines: AnyRecord[]) {\n return lines.map((line) => {\n const total = Number(line.total_ht ?? (Number(line.quantite || 0) * Number(line.prix_unitaire_ht || 0)));\n return `\n

${esc(line.designation)}

${esc(line.type_ligne || \"prestation\")}

\n ${esc(Number(line.quantite || 0).toLocaleString(\"fr-FR\"))}\n ${esc(line.unite || \"u\")}\n ${money(line.prix_unitaire_ht)}\n ${esc(Number(line.tva_taux || 0).toLocaleString(\"fr-FR\"))} %\n ${money(total)}\n `;\n }).join(\"\");\n}\n\nfunction totalsBlock(document: AnyRecord) {\n if (document?.is_estimate && document?.estimation_min_ttc != null && document?.estimation_max_ttc != null) {\n return `

Base estimative HT${money(document.total_ht)}

Fourchette TTC${money(document.estimation_min_ttc)} – ${money(document.estimation_max_ttc)}

`;\n }\n return `

Total HT${money(document.total_ht)}

TVA${money(document.total_tva)}

Total TTC${money(document.total_ttc)}

`;\n}\n\nconst BASE_CSS = `\n:root{--ink:#17212b;--muted:#65717d;--line:#dfe5e8;--brand:#0f766e;--soft:#e8f5f2;--paper:#fff;--bg:#111820}\n*{box-sizing:border-box}html{background:var(--bg)}body{margin:0;font:14px/1.55 Inter,ui-sans-serif,system-ui,-apple-system,\"Segoe UI\",sans-serif;color:var(--ink);background:var(--bg);padding:28px;text-rendering:optimizeLegibility;-webkit-font-smoothing:antialiased}\n.toolbar{max-width:1000px;margin:0 auto 14px;display:flex;gap:8px;justify-content:flex-end}.toolbar button,.toolbar a{border:1px solid #33414d;background:#1b2630;color:#e9f0f4;padding:9px 13px;border-radius:10px;text-decoration:none;font-weight:750}.toolbar .primary{background:#0f766e;border-color:#0f766e;color:#fff}\n.paper{width:210mm;min-height:297mm;margin:auto;background:var(--paper);padding:18mm 17mm 15mm;box-shadow:0 24px 70px rgba(0,0,0,.35);position:relative}\n.header{display:grid;grid-template-columns:1fr auto;gap:30px;align-items:start;border-bottom:3px solid var(--brand);padding-bottom:18px}.brand h1{font-size:24px;margin:0 0 7px;letter-spacing:-.03em}.brand p{margin:2px 0;color:var(--muted);font-size:13px}.doc-title{text-align:right}.doc-title .kind{text-transform:uppercase;letter-spacing:.12em;color:var(--brand);font-size:12px;font-weight:850}.doc-title h2{font-size:31px;margin:3px 0 4px;letter-spacing:-.045em}.doc-title .status{display:inline-block;padding:5px 10px;border-radius:999px;background:var(--soft);color:var(--brand);font-size:12px;font-weight:800;text-transform:capitalize}\n.meta-grid{display:grid;grid-template-columns:1fr 1fr;gap:32px;margin:24px 0}.box{border:1px solid var(--line);border-radius:12px;padding:15px}.box-label{text-transform:uppercase;letter-spacing:.08em;color:var(--muted);font-size:10.5px;font-weight:850;margin-bottom:8px}.box strong{font-size:16px}.box p{margin:4px 0;color:var(--muted);font-size:13px}\n.subject{background:#f6f8f9;border-radius:12px;padding:14px 16px;margin-bottom:18px}.subject span{color:var(--muted);font-size:11px;text-transform:uppercase;letter-spacing:.08em;font-weight:800}.subject strong{display:block;margin-top:4px;font-size:15px}\ntable{width:100%;border-collapse:collapse;margin-top:8px}th{text-align:left;padding:10px 8px;border-bottom:2px solid var(--ink);font-size:10.5px;text-transform:uppercase;letter-spacing:.07em;color:var(--muted)}td{padding:12px 8px;border-bottom:1px solid var(--line);vertical-align:top;font-size:13px}.num{text-align:right}.strong{font-weight:800}.designation{font-weight:750;font-size:13.5px}.line-kind{font-size:10.5px;color:var(--muted);text-transform:uppercase;letter-spacing:.04em;margin-top:2px}\n.summary{display:grid;grid-template-columns:1fr 290px;gap:30px;margin-top:22px}.notes{color:var(--muted);font-size:12.5px}.notes strong{display:block;color:var(--ink);margin-bottom:6px;font-size:13.5px}.totals{border:1px solid var(--line);border-radius:12px;overflow:hidden}.totals div{display:flex;justify-content:space-between;padding:10px 13px;border-bottom:1px solid var(--line);font-size:13px}.totals div:last-child{border-bottom:0}.totals span{color:var(--muted)}.totals .grand{background:var(--ink);color:#fff;padding:14px 13px}.totals .grand span{color:#cbd5dc}.totals .grand strong{font-size:20px}\n.payment{margin-top:22px;border-left:4px solid var(--brand);background:var(--soft);padding:14px 16px;border-radius:0 10px 10px 0}.payment strong{display:block;margin-bottom:5px;font-size:14px}.payment p{margin:3px 0;color:#35504e;font-size:12.5px}.footer{position:absolute;left:17mm;right:17mm;bottom:12mm;border-top:1px solid var(--line);padding-top:9px;display:flex;justify-content:space-between;gap:20px;color:var(--muted);font-size:10px}.legal{margin-top:20px;font-size:10px;line-height:1.45;color:var(--muted)}\n@media(max-width:850px){body{padding:0}.toolbar{position:sticky;top:0;z-index:2;background:#111820;padding:10px;margin:0}.paper{width:100%;min-height:100vh;padding:25px 20px;box-shadow:none}.meta-grid,.summary{grid-template-columns:1fr}.footer{position:static;margin-top:35px}.doc-title h2{font-size:24px}}\n@media print{@page{size:A4;margin:0}html,body{background:#fff}.toolbar{display:none}.paper{box-shadow:none;margin:0;width:210mm;min-height:297mm}.footer{position:absolute}}\n`;\n\nfunction shell(content: string, title: string, nonce: string) {\n return `${esc(title)}${content}`;\n}\n\nexport function quotePage(data: AnyRecord, nonce: string): string {\n const quote = data.devis || {};\n const client = clientBlock(data.client || {});\n const company = companyBlock(data.settings || {});\n const lines = Array.isArray(data.lignes) ? data.lignes : [];\n const validUntil = quote.date_emission ? new Date(new Date(quote.date_emission).getTime() + Number(quote.validite_jours || 30) * 86400000) : null;\n const deposit = Number(quote.total_ttc || 0) * Number(quote.acompte_pct || 0) / 100;\n const content = `

\n \n

Destinataire

${esc(client.name)}

${client.address || \"Adresse non renseignée\"}

${esc([client.phone,client.email].filter(Boolean).join(\" · \"))}

Informations

Date d’émission : ${dateFr(quote.date_emission)}

Valable jusqu’au : ${dateFr(validUntil)}

${quote.is_estimate ? `

Nature : fourchette non contractuelle

` : `

Acompte à la commande : ${money(deposit)} (${esc(quote.acompte_pct || 0)} %)

Objet${esc(quote.objet || \"Prestations piscine\")}

\n ${lineRows(lines) || ``}

Désignation	Qté	Unité	Prix HT	TVA	Total HT
Aucune ligne renseignée.

Notes et conditions

${esc(quote.notes || company.quoteTerms)}

${totalsBlock(quote)}

${quote.is_estimate ? `Prochaine étape

Cette estimation doit être confirmée après diagnostic ou visite technique avant tout engagement.

` : `Acceptation du devis

Bon pour accord, date et signature du client précédées de la mention « Lu et approuvé ».

${company.iban ? `

IBAN pour l’acompte : ${esc(company.iban)}

` : \"\"}`}

${esc(company.quoteTerms)}

\n \n

`;\n return shell(content, `Devis ${quote.numero || \"\"}`, nonce);\n}\n\nexport function invoicePage(data: AnyRecord, nonce: string): string {\n const invoice = data.facture || {};\n const quote = data.devis || {};\n const client = clientBlock(data.client || {});\n const company = companyBlock(data.settings || {});\n const allLines = Array.isArray(data.lignes) ? data.lignes : [];\n const isFull = invoice.type_facture === \"simple\";\n const invoiceLines = isFull ? allLines : [{\n designation: `${invoice.type_facture === \"acompte\" ? \"Acompte\" : \"Solde\"} sur devis ${quote.numero || \"\"} — ${quote.objet || \"Prestations piscine\"}`,\n type_ligne: invoice.type_facture || \"facturation\",\n quantite: 1,\n unite: \"forfait\",\n prix_unitaire_ht: invoice.total_ht,\n tva_taux: Number(invoice.total_ht || 0) ? Number(invoice.total_tva || 0) / Number(invoice.total_ht || 1) * 100 : 0,\n total_ht: invoice.total_ht,\n }];\n const paid = String(invoice.statut || \"\").toLowerCase() === \"payee\";\n const content = `

\n \n

Facturé à

${esc(client.name)}

${client.address || \"Adresse non renseignée\"}

${esc([client.phone,client.email].filter(Boolean).join(\" · \"))}

Informations

Date d’émission : ${dateFr(invoice.date_emission)}

Échéance : ${dateFr(invoice.date_echeance)}

${paid ? `

Payée le : ${dateFr(invoice.date_paiement)}

Mode : ${esc(invoice.mode_paiement || \"\")}

` : \"\"}

Référence${esc(quote.objet || `Devis ${quote.numero || \"\"}`)}

\n ${lineRows(invoiceLines)}

Désignation	Qté	Unité	Prix HT	TVA	Total HT

Notes

${esc(invoice.notes || company.invoiceTerms)}

${totalsBlock(invoice)}

${paid ? \"Paiement reçu\" : \"Modalités de paiement\"}${paid ? `

Cette facture est acquittée.

` : `

Montant à régler avant le ${dateFr(invoice.date_echeance)}.

${company.iban ? `

Virement bancaire — IBAN : ${esc(company.iban)}

` : \"\"}`}

${esc(company.invoiceTerms)}

\n \n

`;\n return shell(content, `Facture ${invoice.numero || \"\"}`, nonce);\n}\n",[],[448,593],"39f67356-08b7-4032-bb48-970bf3575ad1","client-v9.ts","019f66f6-e506-776c-9df7-68a0710f035a",["D",1784138884418],"export const CSS_V9 = String.raw`\n:root{--text-xs:11px;--text-sm:12px;--text-md:14px;--text-lg:16px;--focus:0 0 0 3px rgba(53,209,181,.16)}\nbody{font-size:15px;line-height:1.55;text-rendering:optimizeLegibility;-webkit-font-smoothing:antialiased}\nbutton,input,select,textarea{font-size:14px;line-height:1.35}\n.shell{grid-template-columns:256px minmax(0,1fr)}\n.side{padding:24px 18px;gap:26px}.brand-mark{width:42px;height:42px}.brand b{font-size:16px}.brand span{font-size:11px}.nav{gap:6px}.nav button{min-height:42px;padding:10px 13px;font-size:14px}.side-foot{font-size:12px;line-height:1.5}\n.topbar{height:78px;padding:0 32px}.page-title{font-size:18px}.search-trigger{min-height:42px;font-size:13px}.kbd{font-size:11px}.content{max-width:1580px;padding:32px clamp(20px,3vw,42px) 72px}\n.hero{align-items:flex-start;margin-bottom:24px}.eyebrow{font-size:12px;letter-spacing:.1em}.hero h1{font-size:clamp(30px,3vw,38px);line-height:1.05}.hero p{font-size:14px;max-width:720px}.hero-state strong{font-size:28px}.hero-state span{font-size:12px}\n.grid{gap:18px}.kpis{gap:14px;margin-bottom:18px}.card{border-radius:16px}.pad{padding:20px}.kpi{padding:19px}.kpi .label{font-size:12px}.kpi .value{font-size:30px}.kpi .meta{font-size:12px}.card-head{padding:17px 20px}.card-head h2{font-size:15px}.card-head .count{font-size:12px}.empty{font-size:13px}\n.btn{min-height:40px;padding:10px 14px;border-radius:11px;font-size:13px}.btn.small{min-height:34px;padding:7px 10px;font-size:12px}.quick{min-height:82px;padding:16px}.quick b{font-size:14px}.quick span{font-size:12px;line-height:1.4}\n.list li{padding:15px 20px;gap:13px}.list .grow b{font-size:14px}.sub,.time{font-size:12px;line-height:1.45}.pill{font-size:11px;padding:5px 9px}.mark{width:10px;height:10px}\n.toolbar{gap:12px;margin-bottom:16px}.field{gap:7px;margin-bottom:15px}.field label{font-size:12px}.field input,.field select,.field textarea{min-height:42px;padding:11px 12px;font-size:14px}.field textarea{min-height:104px}.field input:focus,.field select:focus,.field textarea:focus{box-shadow:var(--focus)}.check span{font-size:13px}.check input{width:18px;height:18px}\n.table{min-width:840px}.table th{font-size:11px;padding:12px 16px}.table td{padding:15px 16px;font-size:14px}.table b{font-size:14px}.segmented button{min-height:36px;padding:8px 12px;font-size:12px}\n.action-center{gap:10px;padding:14px}.action-item{padding:14px}.action-item strong{font-size:14px}.action-item p,.action-item .score{font-size:12px}.insight{padding:18px}.insight span{font-size:12px}.insight strong{font-size:23px}.definition dt{font-size:12px}.definition dd{font-size:14px}.blocker{font-size:12px;padding:13px 14px}\n#actionDialog{width:min(1120px,calc(100vw - 32px))}#searchDialog{width:min(700px,calc(100vw - 32px))}dialog{max-height:calc(100dvh - 24px);border-radius:20px}.dialog-head{position:sticky;top:0;z-index:5;padding:18px 22px;background:rgba(16,25,34,.97);backdrop-filter:blur(14px)}.dialog-head h2{font-size:18px}.dialog-head button{min-width:40px;min-height:40px;font-size:25px}.dialog-body{padding:22px;max-height:calc(100dvh - 88px)}.dialog-foot{position:sticky;bottom:-22px;z-index:4;margin:14px -2px 0;padding:15px 2px 2px;background:linear-gradient(180deg,rgba(16,25,34,0),var(--panel) 28%)}.result{font-size:13px;padding:14px}.search-box{font-size:16px;padding:18px 20px}.search-result{padding:15px 20px}.search-result b{font-size:14px}.search-result span{font-size:12px}\n.quote-head{grid-template-columns:minmax(0,1.08fr) minmax(320px,.92fr);gap:16px}.quote-line{grid-template-columns:120px minmax(250px,1fr) 86px 86px 128px 92px 42px;gap:8px;padding:10px;border:1px solid var(--line);border-radius:12px;background:#0d161d;margin-bottom:10px}.quote-line input,.quote-line select{min-height:40px;background:#111e27}.quote-line .btn{min-height:40px}.quote-summary{font-size:13px;gap:24px}.quote-summary strong{font-size:18px}\n.detail-stat span,.detail-section h3,.field-help,.next-step p{font-size:12px}.detail-stat strong{font-size:19px}.proof{font-size:12px}.score-ring{width:56px;height:56px;font-size:12px}\n.flow-hero,.flow-actions{padding:22px}.flow-hero h2{font-size:24px}.flow-hero .sub{font-size:13px}.flow-ring{grid-template-columns:64px 1fr;gap:12px;padding:13px}.flow-ring svg{width:64px;height:64px}.flow-ring strong{font-size:19px}.flow-ring span{font-size:11px;line-height:1.35}.flow-actions h3{font-size:18px}.flow-action{padding:12px 13px}.flow-action b{font-size:13px}.flow-action small{font-size:11px;line-height:1.35}.aging-head{font-size:11px}.aging-values span{font-size:10px}.aging-values b{font-size:12px}\n.doc-v8{grid-template-columns:minmax(0,1.3fr) minmax(260px,.7fr);padding:19px;gap:18px}.doc-v8-head b{font-size:16px}.doc-v8-sub{font-size:12px;line-height:1.45;max-width:760px}.doc-v8-money{font-size:29px}.doc-v8-proof{font-size:11px}.stage-label-v8{font-size:10px}.doc-v8-actions{gap:8px}.doc-v8-actions .primary{min-width:140px}\n.invoice-choice{padding:16px}.invoice-choice b{font-size:14px}.invoice-choice span{font-size:11px}.invoice-choice strong{font-size:18px}.auto-send{padding:15px}.auto-send input{width:18px;height:18px}.auto-send b{font-size:13px}.auto-send span{font-size:11px}.verification-card{padding:18px}.verification-card h3{font-size:16px}.verification-card p{font-size:12px}.verification-meta span,.result-split span{font-size:10px}.verification-meta strong,.result-split strong{font-size:13px}.status-note{font-size:12px}\n.document-tools{gap:12px}.document-tools input{max-width:420px}.flow-filter select{min-height:40px;font-size:12px}.document-empty-action p{font-size:13px}\n.toast{font-size:13px;line-height:1.4;padding:13px 16px}.login-card{width:min(430px,100%);padding:32px}.login-card h1{font-size:28px}.login-card p{font-size:14px}.login-error{font-size:12px}\n@media(max-width:1200px){.shell{grid-template-columns:226px minmax(0,1fr)}.content{padding-inline:24px}.doc-v8{grid-template-columns:1fr}.doc-v8-actions{justify-content:flex-start}.quote-line{grid-template-columns:105px minmax(210px,1fr) 78px 78px 112px 84px 40px}}\n@media(max-width:850px){.side{padding:10px 12px}.nav{scroll-snap-type:x proximity;scrollbar-width:none}.nav::-webkit-scrollbar{display:none}.nav button{scroll-snap-align:start;min-height:40px;font-size:12px}.topbar{top:58px;height:66px}.content{padding:22px 16px 56px}.hero{flex-wrap:wrap;gap:14px}.hero>.actions,.hero>button{width:auto}.flow-v8{grid-template-columns:1fr}.flow-rings{grid-template-columns:repeat(3,minmax(0,1fr))}.quote-head{grid-template-columns:1fr}}\n@media(max-width:700px){body{font-size:14px}.topbar{padding:0 12px}.page-title{font-size:16px}.content{padding:18px 12px 48px}.hero h1{font-size:28px}.hero p{font-size:13px}.hero>.actions{width:100%;display:grid;grid-template-columns:1fr 1fr}.hero>.actions .btn{width:100%}.kpi{padding:16px}.kpi .label{font-size:12px}.kpi .value{font-size:24px}.quick-grid{gap:10px}.quick{min-height:76px}.toolbar{width:100%}.toolbar .field,.toolbar .segmented{flex:1 1 100%}.segmented{overflow:auto}.table-wrap{display:none}.mobile-list{display:block}.definition{grid-template-columns:1fr}.definition dt{padding-bottom:2px;border-bottom:0}.definition dd{padding-top:2px}.flow-rings{grid-template-columns:1fr}.flow-ring{grid-template-columns:58px 1fr}.flow-ring svg{width:58px;height:58px}.doc-v8{padding:16px}.doc-v8-money{font-size:25px}.doc-v8-actions{display:grid;grid-template-columns:1fr 1fr}.doc-v8-actions .btn{width:100%;min-width:0}.stage-label-v8{font-size:9px}.invoice-choice-grid{grid-template-columns:1fr}.quote-live-summary{grid-template-columns:1fr 1fr}.result-split,.verification-meta{grid-template-columns:1fr}.flow-filter{width:100%;margin:0}.flow-filter select{width:100%}#actionDialog,#searchDialog{width:calc(100vw - 10px);max-height:calc(100dvh - 10px);border-radius:16px}.dialog-head{padding:15px 16px}.dialog-body{padding:16px;max-height:calc(100dvh - 76px)}.dialog-foot{bottom:-16px;margin-inline:0}.quote-line{grid-template-columns:minmax(0,1fr) minmax(92px,.42fr);gap:9px;padding:12px}.quote-line [name=designation]{grid-column:1/-1;grid-row:1}.quote-line .kind{display:block;grid-column:1;grid-row:2}.quote-line [name=quantite]{grid-column:2;grid-row:2}.quote-line .unit{display:block;grid-column:1;grid-row:3}.quote-line .price{grid-column:2;grid-row:3}.quote-line .vat{display:block;grid-column:1;grid-row:4}.quote-line .btn{grid-column:2;grid-row:4;width:100%}.quote-summary{display:grid;grid-template-columns:repeat(3,1fr);gap:8px}.quote-summary span{text-align:center}.quote-summary strong{display:block}.document-tools{align-items:stretch;flex-direction:column}.document-tools input{max-width:none}.toast{left:10px;right:10px;bottom:10px;max-width:none}}\n@media(max-width:420px){.topbar .btn.primary{min-width:42px;padding-inline:10px}.search-trigger{min-width:42px;padding-inline:10px}.hero>.actions{grid-template-columns:1fr}.doc-v8-actions{grid-template-columns:1fr}.quote-live-summary,.quote-summary{grid-template-columns:1fr 1fr}.aging-values{grid-template-columns:1fr 1fr}.login{padding:12px}.login-card{padding:24px}}\n`;\n\nexport const CLIENT_V9 = String.raw`\nfunction v9ImproveControls(root=document){\n root.querySelectorAll('.quote-line').forEach(row=>{\n const labels={type_ligne:'Type',designation:'Désignation',quantite:'Quantité',unite:'Unité',prix_unitaire_ht:'Prix HT',tva_taux:'TVA'};\n Object.entries(labels).forEach(([name,label])=>{const el=row.querySelector('[name=\"'+name+'\"]');if(el){el.setAttribute('aria-label',label);el.setAttribute('title',label);if(el.tagName==='INPUT'&&!el.getAttribute('placeholder'))el.setAttribute('placeholder',label)}});\n });\n}\nconst v9Observer=new MutationObserver(m=>{for(const change of m)for(const node of change.addedNodes)if(node.nodeType===1)v9ImproveControls(node)});\nv9Observer.observe(document.body,{childList:true,subtree:true});\nv9ImproveControls();\n`;\n",[],[448,600],"ba267c96-2cd8-4733-a620-d677fb2af108","client-v8.ts","019f66f6-e506-776c-9df7-65829e0a7f84",["D",1784138884418],"export const CSS_V8 = String.raw`\n.flow-v8{display:grid;grid-template-columns:minmax(0,1.4fr) minmax(320px,.6fr);gap:14px;margin-bottom:16px}.flow-hero{padding:20px}.flow-hero h2{margin:5px 0 2px;font-size:21px;letter-spacing:-.035em}.flow-rings{display:grid;grid-template-columns:repeat(3,1fr);gap:9px;margin-top:16px}.flow-ring{display:grid;grid-template-columns:54px 1fr;align-items:center;gap:9px;padding:10px;border:1px solid var(--line);border-radius:14px;background:#0c151c}.flow-ring svg{width:54px;height:54px;transform:rotate(-90deg)}.flow-ring circle{fill:none;stroke-width:7}.flow-ring .track{stroke:#25343e}.flow-ring .meter{stroke:var(--accent);stroke-linecap:round}.flow-ring.blue .meter{stroke:var(--blue)}.flow-ring.warn .meter{stroke:var(--warn)}.flow-ring strong{display:block;font-size:16px}.flow-ring span{display:block;color:var(--muted);font-size:8px}.flow-actions{padding:20px}.flow-actions h3{margin:5px 0 12px}.flow-action{width:100%;display:grid;grid-template-columns:auto 1fr auto;align-items:center;gap:9px;border:1px solid var(--line);background:#0c151c;color:var(--ink);padding:10px 11px;border-radius:12px;text-align:left;margin-top:7px}.flow-action:hover{border-color:#3e6962}.flow-action small{display:block;color:var(--muted)}.aging{margin-top:15px}.aging-head{display:flex;justify-content:space-between;color:var(--muted);font-size:9px}.aging-bar{display:grid;grid-template-columns:repeat(4,1fr);gap:3px;height:9px;margin-top:7px}.aging-bar i{display:block;border-radius:999px;opacity:.3}.aging-bar i.has{opacity:1}.aging-current{background:var(--accent)}.aging-15{background:var(--blue)}.aging-30{background:var(--warn)}.aging-late{background:var(--danger)}.aging-values{display:grid;grid-template-columns:repeat(4,1fr);gap:5px;margin-top:7px}.aging-values span{font-size:7px;color:var(--muted)}.aging-values b{display:block;font-size:9px;color:var(--ink);margin-top:2px}.doc-v8{display:grid;grid-template-columns:minmax(0,1.25fr) minmax(225px,.55fr);gap:14px;padding:17px;border:1px solid var(--line);border-radius:17px;background:linear-gradient(145deg,#111d26,#0d171e);position:relative;overflow:hidden}.doc-v8:before{content:'';position:absolute;left:0;top:0;bottom:0;width:4px;background:#60727b}.doc-v8.action:before{background:var(--blue)}.doc-v8.good:before{background:var(--ok)}.doc-v8.warn:before{background:var(--warn)}.doc-v8.late:before{background:var(--danger)}.doc-v8-head{display:flex;gap:8px;align-items:center;flex-wrap:wrap}.doc-v8-head b{font-size:14px}.doc-v8-sub{color:var(--muted);font-size:10px;margin-top:4px}.doc-v8-money{font-size:24px;font-weight:930;letter-spacing:-.04em;margin-top:12px}.doc-v8-proof{color:var(--ok);font-size:9px;margin-top:5px}.doc-v8-proof.warn{color:var(--warn)}.doc-v8-side{display:flex;flex-direction:column;justify-content:space-between;gap:12px}.stage-v8{display:flex;gap:4px}.stage-v8 i{height:5px;flex:1;border-radius:999px;background:#263640}.stage-v8 i.done{background:var(--accent)}.stage-v8 i.now{background:var(--blue)}.stage-label-v8{display:flex;justify-content:space-between;color:var(--muted);font-size:7px;margin-top:5px}.doc-v8-actions{display:flex;justify-content:flex-end;gap:7px;flex-wrap:wrap}.doc-v8-actions .primary{min-width:125px}.flow-filter{display:flex;gap:8px;margin-left:auto}.flow-filter select{border:1px solid var(--line);background:#0d161d;color:var(--ink);padding:8px 10px;border-radius:10px;font-size:10px}.auto-send{display:flex;gap:10px;align-items:flex-start;padding:13px;border:1px solid #315b53;background:#102622;border-radius:13px;margin-top:13px}.auto-send input{margin-top:3px}.auto-send b{display:block}.auto-send span{display:block;color:#96bab3;font-size:9px;margin-top:2px}.result-split{display:grid;grid-template-columns:1fr 1fr;gap:8px;margin-top:12px}.result-split div{padding:11px;border-radius:12px;background:#0c151c;border:1px solid var(--line)}.result-split span{display:block;color:var(--muted);font-size:8px}.result-split strong{display:block;margin-top:4px}.status-note{padding:11px 12px;border-radius:12px;margin-top:12px;background:var(--okbg);color:var(--ok);font-size:10px}.status-note.warn{background:var(--warnbg);color:var(--warn)}\n@media(max-width:980px){.flow-v8,.doc-v8{grid-template-columns:1fr}.doc-v8-actions{justify-content:flex-start}}\n@media(max-width:660px){.flow-rings{grid-template-columns:1fr}.flow-filter{width:100%;margin:0}.flow-filter select{width:100%}.result-split{grid-template-columns:1fr}.stage-label-v8{display:none}}\n`;\n\nexport const CLIENT_V8 = String.raw`\nlet v8Scope='action';\nconst v8Pct=(a,b)=>b?Math.max(0,Math.min(100,Math.round(a/b*100))):0;\nconst v8Ring=(label,value,pct,tone='')=>'

'+esc(value)+''+esc(label)+'

';\nfunction v8Metrics(){const activeQ=quotes.filter(x=>!/expire|refuse/i.test(x.statut||'')),complete=activeQ.filter(v7Complete),sent=quotes.filter(x=>/envoye|accepte/i.test(x.statut||'')),accepted=quotes.filter(x=>/accepte/i.test(x.statut||'')),issued=invoices.filter(x=>!isCancelled(x)),paid=issued.filter(isPaid),now=new Date(todayIso());const open=issued.filter(x=>!isPaid(x)),aging={current:0,d15:0,d30:0,late:0};open.forEach(x=>{const due=x.date_echeance?Math.floor((now-new Date(x.date_echeance))/86400000):-1,amount=Number(x.total_ttc||0);if(due<0)aging.current+=amount;else if(due<=15)aging.d15+=amount;else if(due<=30)aging.d30+=amount;else aging.late+=amount});return{integrity:v8Pct(complete.length,activeQ.length),conversion:v8Pct(accepted.length,sent.length),cash:v8Pct(paid.reduce((s,x)=>s+Number(x.total_ttc||0),0),issued.reduce((s,x)=>s+Number(x.total_ttc||0),0)),correct:activeQ.filter(x=>!v7Complete(x)).length,sendQ:complete.filter(x=>/brouillon|pret/i.test(x.statut||'')).length,invoiceQ:accepted.filter(x=>!hasInvoiceFor(x.id)).length,sendI:invoices.filter(x=>/brouillon/i.test(x.statut||'')).length,collect:open.length,aging}}\nfunction v8RenderFlow(){let host=q('#documentCommand');if(!host){host=document.createElement('div');host.id='documentCommand';q('#view-documents .toolbar').before(host)}const m=v8Metrics(),total=m.aging.current+m.aging.d15+m.aging.d30+m.aging.late||1;host.className='flow-v8';host.innerHTML='

Cycle commercial simplifié

Une action utile par document

Les statuts techniques sont déduits des preuves réelles : base, Gmail et paiement.

'+v8Ring('Devis cohérents',m.integrity+' %',m.integrity)+v8Ring('Devis convertis',m.conversion+' %',m.conversion,'blue')+v8Ring('Montant encaissé',m.cash+' %',m.cash,'warn')+'

Âge des montants à recevoir'+money(total===1?0:total)+'

À venir'+money(m.aging.current)+'1–15 j'+money(m.aging.d15)+'16–30 j'+money(m.aging.d30)+'+30 j'+money(m.aging.late)+'

Actions suivantes

'+(m.correct+m.sendQ+m.invoiceQ+m.sendI+m.collect)+' dossiers à faire avancer

';qa('[data-flow]',host).forEach(b=>b.onclick=()=>{const f=b.dataset.flow;if(f==='correct'){documentTab='quotes';v8Scope='correct'}else if(f==='send-quotes'){documentTab='quotes';v8Scope='send'}else if(f==='invoice'){documentTab='quotes';v8Scope='accepted'}else if(f==='send-invoices'){documentTab='invoices';v8Scope='draft'}else{documentTab='invoices';v8Scope='open'};renderDocuments()})}\nfunction v8QuoteStage(x){if(hasInvoiceFor(x.id))return 4;const s=String(x.statut||'brouillon');return /accepte/.test(s)?3:/envoye/.test(s)?2:/pret/.test(s)?1:0}\nfunction v8InvoiceStage(x){return isPaid(x)?2:/envoyee/.test(String(x.statut||''))?1:0}\nfunction v8Rail(stage,labels){return '

'+labels.map((_,i)=>'').join('')+'

'+labels.map(x=>''+x+'').join('')+'

'}\nfunction v8QuoteCard(x){const complete=v7Complete(x),status=String(x.statut||'brouillon'),client=invoiceClient(x),closed=/expire|refuse/i.test(status),accepted=/accepte/i.test(status),invoiced=hasInvoiceFor(x.id);let primary='';if(!closed&&!complete)primary='';else if(!closed&&!invoiced&&/brouillon|pret/i.test(status))primary='';else if(!closed&&!invoiced&&/envoye/i.test(status))primary='';else if(accepted&&!invoiced)primary='';else primary='';const tone=!complete?'warn':accepted||invoiced?'good':closed?'':'action';return '

'+esc(x.numero||'Devis')+''+pill(status)+'

'+esc(client.nom||client.telephone||'Client')+' · '+esc(x.objet||'Sans objet')+'

'+money(x.total_ttc)+'

'+(complete?'✓ Lignes et totaux cohérents':'⚠ Document à corriger')+'

'+v8Rail(v8QuoteStage(x),['Brouillon','Prêt','Envoyé','Accepté','Facturé'])+'

'+primary+'

'}\nfunction v8InvoiceCard(x){const status=String(x.statut||'brouillon'),overdue=!isPaid(x)&&x.date_echeance&&new Date(x.date_echeance)Consulter':/brouillon/i.test(status)?'':'';const tone=isPaid(x)?'good':overdue?'late':'action';return '

'+esc(x.numero||'Facture')+''+pill(status)+'

'+esc(client.nom||client.telephone||'Client')+' · '+esc(textStatus(x.type_facture||'simple'))+'

'+money(x.total_ttc)+'

'+(isPaid(x)?'✓ Paiement confirmé':overdue?'⚠ Échéance dépassée':'✓ Facture enregistrée')+'

'+v8Rail(v8InvoiceStage(x),['Brouillon','Envoyée','Payée'])+'

'+primary+'

'}\nfunction v8Filter(x){if(documentTab==='quotes'){if(v8Scope==='all')return true;if(v8Scope==='correct')return !v7Complete(x)&&!/expire|refuse/i.test(x.statut||'');if(v8Scope==='send')return v7Complete(x)&&/brouillon|pret/i.test(x.statut||'');if(v8Scope==='accepted')return /accepte/i.test(x.statut||'')&&!hasInvoiceFor(x.id);return !/expire|refuse/i.test(x.statut||'')}if(documentTab==='invoices'){if(v8Scope==='all')return true;if(v8Scope==='draft')return /brouillon/i.test(x.statut||'');if(v8Scope==='paid')return isPaid(x);if(v8Scope==='overdue')return !isPaid(x)&&x.date_echeance&&new Date(x.date_echeance)x.classList.toggle('active',x.dataset.documentTab===documentTab));let card=q('#documentsWorkspace');if(!card){card=q('#documentsBody')?.closest('article.card');if(card)card.id='documentsWorkspace'}if(!card)return;const options=documentTab==='quotes'?'':documentTab==='invoices'?'':'';card.innerHTML='

';if(![...q('#documentScopeV8').options].some(o=>o.value===v8Scope))v8Scope=documentTab==='quotes'?'action':documentTab==='invoices'?'open':'all';q('#documentScopeV8').value=v8Scope;const source=documentTab==='quotes'?quotes:documentTab==='invoices'?invoices:purchases;const filtered=source.filter(v8Filter).filter(x=>!documentSearch||JSON.stringify([x.numero,x.objet,clientName(x),x.statut]).toLowerCase().includes(documentSearch));q('#documentGridV8').innerHTML=filtered.length?filtered.map(x=>documentTab==='quotes'?v8QuoteCard(x):documentTab==='invoices'?v8InvoiceCard(x):purchaseCard(x)).join(''):'

Aucun document dans cette étape

Le cycle est à jour pour ce filtre.

';q('#documentSearchV8').value=documentSearch;q('#documentSearchV8').oninput=e=>{documentSearch=e.target.value.toLowerCase();renderDocuments()};q('#documentScopeV8').onchange=e=>{v8Scope=e.target.value;renderDocuments()};v7BindQuoteActions();bindDocumentActions();v8BindInvoiceActions()}\nasync function v8SendInvoice(id){const button=q('[data-send-invoice=\"'+id+'\"]');if(button)button.disabled=true;try{const check=await action('invoice.get',{id},false);if(!check.facture||Number(check.facture.total_ttc||0)<=0)throw new Error('Facture incomplète');if(!check.client?.email)throw new Error('Adresse e-mail client manquante');const result=await action('invoice.send',{id},false),index=invoices.findIndex(x=>x.id===id);if(index>=0)invoices[index]={...invoices[index],...(result.facture||{}),statut:'envoyee'};renderDocuments();toast(result.message||'Facture envoyée par e-mail')}catch(error){toast(error.message,false);if(button)button.disabled=false}}\nfunction v8BindInvoiceActions(){qa('[data-send-invoice]').forEach(x=>x.onclick=()=>v8SendInvoice(x.dataset.sendInvoice))}\nopenInvoiceDialog=function(devisId){const quote=quotes.find(x=>x.id===devisId)||{};if(!v7Complete(quote)){toast('Corrigez le devis avant de le facturer.',false);return}dialogTitle.textContent='Créer la facture';const simple=amountForInvoice(quote,'simple'),deposit=amountForInvoice(quote,'acompte'),balance=amountForInvoice(quote,'solde');dialogBody.innerHTML='';q('[data-close]',dialogBody).onclick=closeDialog;q('#invoiceFormV8').onsubmit=async event=>{event.preventDefault();const form=event.currentTarget,button=q('[type=submit]',form),proof=q('#invoiceProofV8'),payload=Object.fromEntries(new FormData(form).entries()),auto=payload.auto_send==='on';delete payload.auto_send;payload.devis_id=devisId;button.disabled=true;proof.innerHTML='

Création et relecture de la facture…

';try{const created=await action('invoice.from_quote',payload,false);if(!created.facture?.id)throw new Error(created.error||'Facture non créée');const verified=await action('invoice.get',{id:created.facture.id},false);if(!verified.facture)throw new Error('Facture introuvable après création');const invoice=verifiedInvoiceResult(created,verified);let delivery='Brouillon conservé';if(auto){proof.innerHTML='

Facture créée. Envoi Gmail en cours…

';try{const sent=await action('invoice.send',{id:invoice.id},false);invoice.statut='envoyee';Object.assign(invoice,sent.facture||{});delivery='E-mail confirmé par Gmail'}catch(sendError){delivery='Envoi à reprendre : '+sendError.message}}renderDocuments();proof.innerHTML='

✓

Facture '+(invoice.statut==='envoyee'?'créée et envoyée':'créée')+'

La facture a été relue dans Supabase.

Document'+esc(invoice.numero)+'

Livraison'+esc(delivery)+'

';q('[data-open-created]',proof).onclick=()=>openDoc('invoice',invoice.id);q('[data-close-result]',proof).onclick=()=>{dialog.close();documentTab='invoices';v8Scope=invoice.statut==='envoyee'?'open':'draft';showView('documents');renderDocuments()};toast(invoice.statut==='envoyee'?'Facture créée et envoyée':'Facture créée')}catch(error){proof.innerHTML='

'+esc(error.message)+'

';toast(error.message,false);button.disabled=false}};dialog.showModal()}\nrenderDocuments();\n`;",[],[448,607],"f6696cd0-a0e9-471b-ac00-75f1ec3aad72","client-v7.ts","019f66f6-e506-776c-9df7-62c560eddf16",["D",1784138884418],"export const CSS_V7 = String.raw`\n.lifecycle-lab{display:grid;grid-template-columns:minmax(0,1.25fr) minmax(320px,.75fr);gap:16px;margin-bottom:16px}.lifecycle-panel{padding:20px}.lifecycle-panel h2{font-size:20px;margin:5px 0 2px;letter-spacing:-.03em}.lifecycle-panel p{margin:0;color:var(--muted);font-size:11px}.donut-grid{display:grid;grid-template-columns:repeat(3,1fr);gap:10px;margin-top:17px}.donut-card{display:grid;grid-template-columns:58px 1fr;align-items:center;gap:10px;padding:11px;border:1px solid var(--line);border-radius:14px;background:#0d161d}.donut-card svg{width:58px;height:58px;transform:rotate(-90deg)}.donut-card circle{fill:none;stroke-width:8}.donut-card .track{stroke:#25343e}.donut-card .value-ring{stroke:var(--accent);stroke-linecap:round}.donut-card.warn .value-ring{stroke:var(--warn)}.donut-card.blue .value-ring{stroke:var(--blue)}.donut-card strong{display:block;font-size:17px}.donut-card span{display:block;color:var(--muted);font-size:9px}.next-action-panel{padding:20px;display:flex;flex-direction:column;justify-content:space-between}.next-action-panel h3{margin:5px 0 4px;font-size:16px}.next-action-panel p{margin:0;color:var(--muted);font-size:10px}.next-action-stack{display:grid;gap:7px;margin-top:15px}.next-action-row{display:flex;align-items:center;gap:9px;padding:10px 11px;border-radius:12px;background:#0d161d;border:1px solid var(--line)}.next-action-row b{margin-left:auto}.quote-v7{display:grid;grid-template-columns:minmax(0,1.3fr) minmax(310px,.7fr);gap:14px;padding:17px;border:1px solid var(--line);border-radius:17px;background:linear-gradient(145deg,#111d26,#0e171e);position:relative;overflow:hidden}.quote-v7:before{content:'';position:absolute;left:0;top:0;bottom:0;width:4px;background:var(--blue)}.quote-v7.incomplete:before{background:var(--warn)}.quote-v7.accepted:before{background:var(--ok)}.quote-v7.expired:before,.quote-v7.refused:before{background:#60727b}.quote-v7-main{min-width:0}.quote-v7-title{display:flex;align-items:center;gap:8px;flex-wrap:wrap}.quote-v7-title b{font-size:14px}.quote-v7-sub{color:var(--muted);font-size:10px;margin-top:4px}.quote-v7-total{font-size:24px;font-weight:930;letter-spacing:-.04em;margin-top:13px}.quote-v7-total small{font-size:9px;color:var(--muted);font-weight:750;letter-spacing:0}.quote-integrity{display:flex;gap:7px;align-items:center;margin-top:7px;color:var(--ok);font-size:9px}.quote-integrity.bad{color:var(--warn)}.quote-v7-side{display:flex;flex-direction:column;gap:12px;justify-content:space-between}.quote-stepper{display:grid;grid-template-columns:repeat(5,1fr);gap:4px}.quote-step{height:5px;border-radius:999px;background:#263640}.quote-step.done{background:var(--accent)}.quote-step.current{background:var(--blue);box-shadow:0 0 0 3px rgba(112,167,255,.08)}.quote-step-labels{display:grid;grid-template-columns:repeat(5,1fr);gap:4px;margin-top:5px}.quote-step-labels span{text-align:center;color:var(--muted);font-size:7px}.quote-v7-actions{display:flex;gap:6px;justify-content:flex-end;flex-wrap:wrap}.quote-status-menu{display:flex;gap:6px;align-items:center;justify-content:flex-end}.quote-status-menu select{max-width:145px;border:1px solid var(--line);background:#0d161d;color:var(--ink);padding:7px;border-radius:9px;font-size:10px}.integrity-banner{padding:10px 12px;border:1px solid #2d665b;background:#102a27;border-radius:12px;color:#a8d8d0;font-size:10px}.integrity-banner.warn{border-color:#6b5123;background:#2b2112;color:#e5bd79}.editor-shell{display:grid;gap:14px}.editor-headline{display:flex;align-items:flex-start;justify-content:space-between;gap:14px}.editor-headline h3{margin:4px 0 0}.editor-badge{padding:7px 10px;border-radius:999px;background:#102a27;color:var(--accent);font-size:9px;font-weight:850}.pricing-helpers{display:flex;gap:7px;flex-wrap:wrap;margin-bottom:11px}.pricing-helper{border:1px dashed #3b5661;background:#0d161d;color:#b6c6cc;border-radius:10px;padding:7px 9px;font-size:9px}.pricing-helper:hover{border-color:var(--accent);color:#fff}.quote-live-summary{display:grid;grid-template-columns:repeat(4,1fr);gap:8px;margin-top:13px}.quote-live-summary div{padding:11px;border-radius:12px;background:#0d161d;border:1px solid var(--line)}.quote-live-summary span{display:block;color:var(--muted);font-size:8px;text-transform:uppercase}.quote-live-summary strong{display:block;margin-top:4px;font-size:14px}.save-proof{margin-top:12px;padding:13px;border-radius:13px;background:var(--okbg);color:var(--ok);font-size:10px}.save-proof.bad{background:var(--dangerbg);color:var(--danger)}.document-filter-v7{display:flex;gap:8px;align-items:center;margin-left:auto}.document-filter-v7 select{border:1px solid var(--line);background:#0d161d;color:var(--ink);padding:8px 10px;border-radius:10px;font-size:10px}\n@media(max-width:1000px){.lifecycle-lab,.quote-v7{grid-template-columns:1fr}.quote-v7-actions,.quote-status-menu{justify-content:flex-start}}\n@media(max-width:660px){.donut-grid{grid-template-columns:1fr}.quote-live-summary{grid-template-columns:1fr 1fr}.quote-step-labels{display:none}.document-filter-v7{width:100%;margin:0}.document-filter-v7 select{width:100%}}\n`;\n\nexport const CLIENT_V7 = String.raw`\nlet v7QuoteScope='active';\nconst v7Complete=qv=>Number(qv.total_ttc||0)>0&&Number(qv.lignes_count||0)>0;\nconst v7StatusOrder=['brouillon','pret','envoye','accepte','facture'];\nconst v7Stage=qv=>hasInvoiceFor(qv.id)?4:Math.max(0,v7StatusOrder.indexOf(String(qv.statut||'brouillon')));\nconst v7Percent=(n,d)=>d?Math.max(0,Math.min(100,Math.round(n/d*100))):0;\nfunction v7Donut(label,value,pct,tone=''){return '

'+esc(value)+''+esc(label)+'

'}\nfunction v7RenderLifecycle(){let host=q('#documentCommand');if(!host){host=document.createElement('div');host.id='documentCommand';q('#view-documents .toolbar').before(host)}const active=quotes.filter(x=>!/expire|refuse/i.test(x.statut||'')),complete=active.filter(v7Complete),sent=quotes.filter(x=>/envoye|accepte/i.test(x.statut||'')),accepted=quotes.filter(x=>/accepte/i.test(x.statut||'')),billed=invoices.filter(x=>!isCancelled(x)),paid=billed.filter(isPaid);const integrity=v7Percent(complete.length,active.length),conversion=v7Percent(accepted.length,sent.length),cash=v7Percent(paid.reduce((s,x)=>s+Number(x.total_ttc||0),0),billed.reduce((s,x)=>s+Number(x.total_ttc||0),0));const incomplete=active.filter(x=>!v7Complete(x)).length,toSend=complete.filter(x=>/brouillon|pret/i.test(x.statut||'')).length,toInvoice=accepted.filter(x=>!hasInvoiceFor(x.id)).length;host.className='lifecycle-lab';host.innerHTML='

Intelligence commerciale

Cycle devis → encaissement

Les graphiques utilisent uniquement les documents réellement enregistrés.

'+v7Donut('Intégrité des devis',integrity+' %',integrity,'')+v7Donut('Conversion envoyés',conversion+' %',conversion,'blue')+v7Donut('Montant encaissé',cash+' %',cash,'warn')+'

Prochaines actions

'+((incomplete+toSend+toInvoice)||0)+' décisions utiles

Le cockpit propose uniquement les étapes possibles dans l’état actuel.

Devis à corriger'+incomplete+'

Prêts à envoyer'+toSend+'

À facturer'+toInvoice+'

'}\nfunction v7Steps(x){const stage=v7Stage(x);return '

'+v7StatusOrder.map((_,i)=>'').join('')+'

BrouillonPrêtEnvoyéAcceptéFacturé

'}\nfunction v7QuoteCard(x){const complete=v7Complete(x),status=String(x.statut||'brouillon'),client=invoiceClient(x),expired=/expire/i.test(status),refused=/refuse/i.test(status),accepted=/accepte/i.test(status),invoiced=hasInvoiceFor(x.id),klass=!complete?'incomplete':accepted?'accepted':expired?'expired':refused?'refused':'';let actions='';if(!expired&&!invoiced&&complete)actions+='';if(!complete&&!expired)actions+='';else if(/brouillon|pret/i.test(status)&&!invoiced)actions+='';else if(/envoye/i.test(status)&&!invoiced)actions+='';else if(accepted&&!invoiced)actions+='';const integrity=complete?'

✓ '+esc(x.lignes_count||0)+' ligne(s), totaux vérifiés

':'

⚠ Totaux ou lignes incomplets

';return '

'+esc(x.numero||'Devis')+''+pill(status)+(expired?'Remplacé':'')+'

'+esc(client.nom||client.telephone||'Client')+' · '+esc(x.objet||'Sans objet')+'

'+money(x.total_ttc)+' TTC

'+integrity+'

'+v7Steps(x)+'

'+actions+'

'+(!expired&&!invoiced&&complete?'':'')+'

'}\nconst v7RenderDocumentsBase=renderDocuments;\nrenderDocumentCommand=v7RenderLifecycle;\nrenderDocuments=function(){v7RenderLifecycle();qa('[data-document-tab]').forEach(x=>x.classList.toggle('active',x.dataset.documentTab===documentTab));let card=q('#documentsWorkspace');if(!card){card=q('#documentsBody')?.closest('article.card');if(card)card.id='documentsWorkspace'}if(!card)return;const quoteTools=documentTab==='quotes'?'

':'';card.innerHTML='

'+quoteTools+'

';let source=documentTab==='quotes'?quotes:documentTab==='invoices'?invoices:purchases;if(documentTab==='quotes'){source=source.filter(x=>{if(v7QuoteScope==='all')return true;if(v7QuoteScope==='active')return !/expire|refuse/i.test(x.statut||'');if(v7QuoteScope==='incomplete')return !v7Complete(x);if(v7QuoteScope==='accepted')return /accepte/i.test(x.statut||'');return true})}const filtered=source.filter(x=>{const hay=JSON.stringify([x.numero,x.objet,clientName(x),x.statut,x.type_facture]).toLowerCase();return!documentSearch||hay.includes(documentSearch)});q('#documentGridV6').innerHTML=filtered.length?filtered.map(x=>documentTab==='quotes'?v7QuoteCard(x):documentTab==='invoices'?invoiceCard(x):purchaseCard(x)).join(''):'

Aucun document

Aucun élément ne correspond à ce filtre.

';q('#documentSearchV6').value=documentSearch;q('#documentSearchV6').oninput=e=>{documentSearch=e.target.value.toLowerCase();renderDocuments()};if(q('#v7QuoteScope')){q('#v7QuoteScope').value=v7QuoteScope;q('#v7QuoteScope').onchange=e=>{v7QuoteScope=e.target.value;renderDocuments()}};v7BindQuoteActions();bindDocumentActions()}\nfunction v7SetControl(row,name,value){const el=q('[name=\"'+name+'\"]',row);if(el&&value!==undefined&&value!==null)el.value=String(value)}\nfunction v7AddLine(prefill={}){const row=document.createElement('div');row.className='quote-line';row.innerHTML='';['type_ligne','designation','quantite','unite','prix_unitaire_ht','tva_taux'].forEach(n=>v7SetControl(row,n,prefill[n]??prefill[n==='prix_unitaire_ht'?'prix_ht':n]));q('button',row).onclick=()=>{row.remove();v7Totals()};qa('input,select',row).forEach(x=>x.oninput=v7Totals);q('[name=designation]',row).onchange=()=>{const hit=catalog.find(c=>c.designation===q('[name=designation]',row).value);if(hit){v7SetControl(row,'prix_unitaire_ht',hit.prix_ht||hit.prix_unitaire_ht||0);v7SetControl(row,'tva_taux',hit.tva_taux||20);v7SetControl(row,'unite',hit.unite||'u');v7Totals()}};q('#quoteLinesV7').appendChild(row);v7Totals()}\nfunction v7Totals(){let ht=0,tva=0;qa('.quote-line',dialogBody).forEach(row=>{const line=Number(q('[name=quantite]',row).value||0)*Number(q('[name=prix_unitaire_ht]',row).value||0),rate=Number(q('[name=tva_taux]',row).value||0);ht+=line;tva+=line*rate/100});const pct=Number(q('#quoteFormV7 [name=acompte_pct]')?.value||30);if(q('#v7Ht'))q('#v7Ht').textContent=money(ht);if(q('#v7Tva'))q('#v7Tva').textContent=money(tva);if(q('#v7Ttc'))q('#v7Ttc').textContent=money(ht+tva);if(q('#v7Deposit'))q('#v7Deposit').textContent=money((ht+tva)*pct/100)}\nasync function v7OpenQuoteEditor(id=null){let detail={devis:{},client:{},lignes:[]};if(id){try{detail=await action('quote.get',{id},false)}catch(error){toast(error.message,false);return}}const d=detail.devis||{},c=detail.client||{};dialogTitle.textContent=id?'Modifier '+(d.numero||'le devis'):'Créer un devis';dialogBody.innerHTML='';q('[data-close]',dialogBody).onclick=closeDialog;q('#v7AddLine').onclick=()=>v7AddLine();qa('[data-quick-line]').forEach(btn=>btn.onclick=()=>{const kind=btn.dataset.quickLine;if(kind==='diagnostic')v7AddLine({type_ligne:'forfait',designation:'Diagnostic piscine',quantite:1,unite:'forfait',prix_unitaire_ht:85,tva_taux:20});if(kind==='labor')v7AddLine({type_ligne:'main_oeuvre',designation:'Main-d’œuvre technicien',quantite:1,unite:'h',prix_unitaire_ht:Number(settings.taux_horaire_mo_ht||55),tva_taux:20});if(kind==='travel')v7AddLine({type_ligne:'deplacement',designation:'Forfait déplacement',quantite:1,unite:'forfait',prix_unitaire_ht:45,tva_taux:20})});const initial=Array.isArray(detail.lignes)&&detail.lignes.length?detail.lignes:[{}];initial.forEach(v7AddLine);q('#quoteFormV7 [name=acompte_pct]').oninput=v7Totals;q('#quoteFormV7').onsubmit=async event=>{event.preventDefault();const form=event.currentTarget,button=q('[type=submit]',form),proof=q('#v7SaveProof'),payload=Object.fromEntries(new FormData(form).entries());payload.lines=qa('.quote-line',form).map(row=>({type_ligne:q('[name=type_ligne]',row).value,designation:q('[name=designation]',row).value,quantite:Number(q('[name=quantite]',row).value||0),unite:q('[name=unite]',row).value,prix_unitaire_ht:Number(q('[name=prix_unitaire_ht]',row).value||0),tva_taux:Number(q('[name=tva_taux]',row).value||0)}));if(payload.lines.some(l=>!l.designation||l.quantite<=0||l.prix_unitaire_ht<=0)){proof.innerHTML='

Chaque ligne doit avoir une désignation, une quantité et un prix strictement positifs.

';return}if(id)payload.id=id;button.disabled=true;proof.innerHTML='';try{const result=await action(id?'quote.update':'quote.create',payload,false);if(!result.devis?.id)throw new Error(result.error||'Devis non enregistré');let verified=await action('quote.get',{id:result.devis.id},false);const lineTotal=(verified.lignes||[]).reduce((s,l)=>s+Number(l.total_ht||0)*(1+Number(l.tva_taux||0)/100),0);if(Math.abs(Number(verified.devis?.total_ttc||0)-lineTotal)>.02){await action('quote.recalculate',{id:result.devis.id},false);verified=await action('quote.get',{id:result.devis.id},false)}if(Number(verified.devis?.total_ttc||0)<=0)throw new Error('Le total serveur reste nul');const merged={...verified.devis,client:verified.client,lignes_count:(verified.lignes||[]).length};const index=quotes.findIndex(x=>x.id===merged.id);if(index>=0)quotes[index]=merged;else quotes.unshift(merged);proof.innerHTML='

✓ '+esc(merged.numero)+' enregistré sans doublon · '+money(merged.total_ttc)+' TTC · '+esc(merged.lignes_count)+' ligne(s)

';renderDocuments();toast(id?'Devis corrigé':'Devis créé');setTimeout(()=>dialog.close(),900)}catch(error){proof.innerHTML='

'+esc(error.message)+'

';toast(error.message,false);button.disabled=false}};dialog.showModal()}\nasync function v7ChangeStatus(id,status){try{const result=await action('quote.status',{id,statut:status},false),index=quotes.findIndex(x=>x.id===id);if(index>=0&&result.devis)quotes[index]={...quotes[index],...result.devis};renderDocuments();toast('Statut mis à jour')}catch(error){toast(error.message,false)}}\nasync function v7SendQuote(id){const button=q('[data-send-quote=\"'+id+'\"]');if(button)button.disabled=true;try{await action('quote.recalculate',{id},false);const check=await action('quote.get',{id},false);if(!check.devis||Number(check.devis.total_ttc||0)<=0||(check.lignes||[]).length===0)throw new Error('Devis incomplet');if(!check.client?.email)throw new Error('Adresse e-mail client manquante');const result=await action('quote.send',{id},false),index=quotes.findIndex(x=>x.id===id);if(index>=0)quotes[index]={...quotes[index],statut:'envoye',date_envoi:new Date().toISOString()};renderDocuments();toast(result.message||'Devis envoyé par e-mail')}catch(error){toast(error.message,false);if(button)button.disabled=false}}\nfunction v7BindQuoteActions(){qa('[data-edit-quote]').forEach(x=>x.onclick=()=>v7OpenQuoteEditor(x.dataset.editQuote));qa('[data-send-quote]').forEach(x=>x.onclick=()=>v7SendQuote(x.dataset.sendQuote));qa('[data-status-quote]').forEach(x=>x.onclick=()=>v7ChangeStatus(x.dataset.statusQuote,x.dataset.nextStatus));qa('[data-apply-status]').forEach(x=>x.onclick=()=>v7ChangeStatus(x.dataset.applyStatus,q('[data-status-select=\"'+x.dataset.applyStatus+'\"]')?.value||'brouillon'))}\nopenQuoteDialog=function(){v7OpenQuoteEditor(null)};\nqa('[data-open-quote]').forEach(x=>x.onclick=()=>v7OpenQuoteEditor(null));\nrenderDocuments();\n`;\n",[],[448,614],"46fe2b1e-f405-4a7e-ac05-dbf6bfbe423e","client-v6.ts","019f66f6-e506-776c-9df7-5ce800ce57af",["D",1784138884418],"export const CSS_V6 = String.raw`\n.document-command{display:grid;grid-template-columns:1.1fr .9fr;gap:16px;margin-bottom:18px}.doc-overview{padding:20px;position:relative;overflow:hidden}.doc-overview:after{content:'';position:absolute;width:220px;height:220px;border-radius:50%;background:radial-gradient(circle,rgba(53,209,181,.16),transparent 68%);right:-70px;top:-90px}.doc-overview h2{font-size:20px;margin:6px 0 3px;letter-spacing:-.03em}.doc-overview p{margin:0;color:var(--muted);font-size:11px}.pipeline-track{display:grid;grid-template-columns:repeat(4,1fr);gap:7px;margin-top:18px}.pipeline-stage{position:relative;padding:11px;border:1px solid var(--line);border-radius:13px;background:#0d161d;min-height:72px}.pipeline-stage:before{content:'';position:absolute;left:0;top:0;bottom:0;width:3px;border-radius:13px 0 0 13px;background:#60727b}.stage-draft:before{background:#8fa3ad}.stage-ready:before{background:#70a7ff}.stage-accepted:before{background:#f1b75b}.stage-invoiced:before{background:#55d692}.pipeline-stage span{display:block;color:var(--muted);font-size:9px;text-transform:uppercase;letter-spacing:.08em}.pipeline-stage strong{display:block;font-size:18px;margin-top:5px}.cash-panel{padding:20px;display:flex;flex-direction:column;justify-content:space-between}.cash-ring{width:112px;height:112px;border-radius:50%;display:grid;place-items:center;margin:4px auto 12px;background:#23343e;position:relative}.cash-none{background:#23343e}.cash-low{background:conic-gradient(var(--accent) 25%,#23343e 0)}.cash-mid{background:conic-gradient(var(--accent) 50%,#23343e 0)}.cash-high{background:conic-gradient(var(--accent) 75%,#23343e 0)}.cash-full{background:conic-gradient(var(--accent) 100%,#23343e 0)}.cash-ring:before{content:'';position:absolute;inset:10px;background:var(--panel);border-radius:50%}.cash-ring div{position:relative;text-align:center}.cash-ring strong{display:block;font-size:20px}.cash-ring span{font-size:9px;color:var(--muted)}.cash-legend{display:grid;grid-template-columns:1fr 1fr;gap:8px}.cash-legend div{padding:9px;border-radius:11px;background:#0d161d}.cash-legend span{display:block;font-size:9px;color:var(--muted)}.cash-legend strong{font-size:12px}.document-tools{display:flex;gap:10px;align-items:center;margin-bottom:13px}.document-tools input{max-width:300px}.document-grid{display:grid;gap:10px}.document-card{display:grid;grid-template-columns:minmax(0,1.45fr) .7fr .7fr auto;align-items:center;gap:16px;padding:15px 17px;border:1px solid var(--line);border-radius:15px;background:linear-gradient(135deg,#101a22,#111d26);position:relative;overflow:hidden}.document-card:before{content:'';position:absolute;left:0;top:0;bottom:0;width:3px;background:#60727b}.doc-incomplete:before{background:#f1b75b}.doc-accepted:before,.doc-paid:before{background:#55d692}.doc-default:before{background:#70a7ff}.doc-overdue:before{background:#ff7a70}.doc-purchase:before{background:#8fa3ad}.document-card:hover{border-color:#36505b;transform:translateY(-1px)}.doc-main b{font-size:13px}.doc-main .sub{max-width:520px}.doc-metric span{display:block;color:var(--muted);font-size:9px;text-transform:uppercase;letter-spacing:.06em}.doc-metric strong{display:block;font-size:14px;margin-top:3px}.doc-alert{margin-top:7px;font-size:9px;color:var(--warn)}.doc-actions{display:flex;justify-content:flex-end;gap:6px;flex-wrap:wrap}.doc-proof{display:inline-flex;align-items:center;gap:5px;font-size:9px;color:var(--ok);margin-top:7px}.doc-proof:before{content:'✓';width:15px;height:15px;border-radius:50%;display:grid;place-items:center;background:var(--okbg)}.invoice-choice-grid{display:grid;grid-template-columns:repeat(3,1fr);gap:9px;margin:14px 0}.invoice-choice{position:relative;border:1px solid var(--line);background:#0d161d;padding:14px;border-radius:14px;cursor:pointer}.invoice-choice input{position:absolute;opacity:0}.invoice-choice:has(input:checked){border-color:var(--accent);background:#102a27;box-shadow:0 0 0 2px rgba(53,209,181,.08)}.invoice-choice b{display:block}.invoice-choice span{display:block;color:var(--muted);font-size:9px;margin-top:3px}.invoice-choice strong{display:block;color:var(--accent);font-size:16px;margin-top:9px}.verification-card{padding:16px;border:1px solid #2b655a;background:#0f2926;border-radius:15px;margin-top:13px}.verification-card .seal{display:flex;align-items:center;gap:10px}.verification-card .seal i{width:35px;height:35px;border-radius:50%;display:grid;place-items:center;background:var(--accent);color:#06251f;font-style:normal;font-weight:950}.verification-card h3{margin:0;font-size:14px}.verification-card p{margin:3px 0 0;color:#9bc1ba;font-size:10px}.verification-meta{display:grid;grid-template-columns:repeat(3,1fr);gap:7px;margin-top:12px}.verification-meta div{padding:9px;background:rgba(0,0,0,.15);border-radius:10px}.verification-meta span{display:block;font-size:8px;color:#80aaa3;text-transform:uppercase}.verification-meta strong{font-size:11px}.legacy-warning{display:inline-flex;align-items:center;gap:5px;padding:4px 7px;border-radius:999px;background:var(--warnbg);color:var(--warn);font-size:8px;font-weight:850}.document-empty-action{padding:30px;text-align:center}.document-empty-action h3{margin:0 0 5px}.document-empty-action p{margin:0 0 13px;color:var(--muted)}\n@media(max-width:1000px){.document-command{grid-template-columns:1fr}.pipeline-track{grid-template-columns:repeat(2,1fr)}.document-card{grid-template-columns:minmax(0,1fr) .65fr auto}.document-card .doc-date{display:none}}\n@media(max-width:660px){.document-card{grid-template-columns:1fr;gap:9px}.doc-actions{justify-content:flex-start}.invoice-choice-grid{grid-template-columns:1fr}.verification-meta{grid-template-columns:1fr 1fr}.pipeline-track{grid-template-columns:1fr 1fr}.document-tools{align-items:stretch;flex-direction:column}.document-tools input{max-width:none}.cash-panel{display:none}}\n`;\n\nexport const CLIENT_V6 = String.raw`\nlet documentSearch='',documentStatus='all';\nconst invoiceClient=(doc)=>doc.client||clients.find(c=>c.id===doc.client_id)||{};\nconst quoteIsComplete=(quote)=>Number(quote.total_ttc||0)>0&&Number(quote.lignes_count||0)>0;\nconst hasInvoiceFor=(quoteId)=>invoices.some(f=>f.devis_id===quoteId&&!/annule/i.test(f.statut||''));\nconst invoiceBalance=()=>invoices.filter(x=>!isPaid(x)&&!isCancelled(x)).reduce((sum,x)=>sum+Number(x.total_ttc||0),0);\nfunction documentMetrics(){const accepted=quotes.filter(x=>/accepte/i.test(x.statut||'')),paid=invoices.filter(isPaid),issued=invoices.filter(x=>!isCancelled(x));return{draft:quotes.filter(x=>/brouillon/i.test(x.statut||'')).length,ready:quotes.filter(x=>/pret|envoye/i.test(x.statut||'')).length,accepted:accepted.length,invoiced:issued.length,pipeline:quotes.filter(x=>!/refuse|expire/i.test(x.statut||'')).reduce((s,x)=>s+Number(x.total_ttc||0),0),billed:issued.reduce((s,x)=>s+Number(x.total_ttc||0),0),paid:paid.reduce((s,x)=>s+Number(x.total_ttc||0),0),due:invoiceBalance()}}\nfunction renderDocumentCommand(){let host=q('#documentCommand');if(!host){host=document.createElement('div');host.id='documentCommand';q('#view-documents .toolbar').before(host)}const m=documentMetrics(),ratio=m.billed?Math.min(100,Math.round(m.paid/m.billed*100)):0,cashClass=ratio<=0?'cash-none':ratio<38?'cash-low':ratio<63?'cash-mid':ratio<88?'cash-high':'cash-full';host.className='document-command';host.innerHTML='

Cycle commercial

'+money(m.pipeline)+' en mouvement

De la proposition au règlement, sans rupture de suivi.

Brouillons'+m.draft+'

Prêts / envoyés'+m.ready+'

Acceptés'+m.accepted+'

Factures'+m.invoiced+'

'+ratio+'%encaissé

Facturé'+money(m.billed)+'

À recevoir'+money(m.due)+'

'}\nfunction documentMatches(x){const hay=JSON.stringify([x.numero,x.objet,clientName(x),x.statut,x.type_facture]).toLowerCase();return(!documentSearch||hay.includes(documentSearch))&&(documentStatus==='all'||String(x.statut||'')===documentStatus)}\nfunction quoteCard(x){const complete=quoteIsComplete(x),invoiced=hasInvoiceFor(x.id),client=invoiceClient(x),docClass=!complete?'doc-incomplete':/accepte/i.test(x.statut||'')?'doc-accepted':'doc-default';let primary='';if(!complete)primary='';else if(!invoiced&&!/refuse|expire/i.test(x.statut||''))primary='';return '

'+esc(x.numero||'Brouillon')+' '+pill(x.statut||'brouillon')+'

'+esc(client.nom||client.telephone||'Client')+' · '+esc(x.objet||'Sans objet')+'

'+(!complete?'

Document historique incomplet : aucune ligne ou aucun montant.

':'

Montants calculés et enregistrés

')+'

Montant TTC'+money(x.total_ttc)+'

Émission'+dateOnly(x.date_emission||x.created_at)+'

'+(String(x.statut)==='brouillon'&&complete?'':'')+primary+'

'}\nfunction invoiceCard(x){const overdue=!isPaid(x)&&x.date_echeance&&new Date(x.date_echeance)

'+esc(x.numero||'Facture')+' '+pill(x.statut||'brouillon')+'

'+esc(client.nom||client.telephone||'Client')+' · '+esc(textStatus(x.type_facture||'simple'))+'

Persistée dans factures

Montant TTC'+money(x.total_ttc)+'

'+(overdue?'Retard':'Échéance')+''+dateOnly(x.date_echeance)+'

'+(!isPaid(x)&&!isCancelled(x)?'':'')+'

'}\nfunction purchaseCard(x){return '

'+esc(x.numero_facture||'Achat')+' '+pill(x.ocr_statut||'en_attente')+'

'+esc(x.fournisseur||'Fournisseur')+'

Montant TTC'+money(x.total_ttc)+'

Date'+dateOnly(x.date_facture||x.created_at)+'

'}\nconst renderDocumentsV5=renderDocuments;\nrenderDocuments=function(){renderDocumentCommand();qa('[data-document-tab]').forEach(x=>x.classList.toggle('active',x.dataset.documentTab===documentTab));let card=q('#documentsWorkspace');if(!card){card=q('#documentsBody')?.closest('article.card');if(card)card.id='documentsWorkspace'}if(!card)return;card.innerHTML='

';const source=documentTab==='quotes'?quotes:documentTab==='invoices'?invoices:purchases;const filtered=source.filter(documentMatches);q('#documentGridV6').innerHTML=filtered.length?filtered.map(x=>documentTab==='quotes'?quoteCard(x):documentTab==='invoices'?invoiceCard(x):purchaseCard(x)).join(''):'

Aucun document ici

Créez un devis complet pour démarrer le cycle commercial.

'+(documentTab==='quotes'?'':'')+'

';q('#documentSearchV6').value=documentSearch;q('#documentStatusV6').value=documentStatus;q('#documentSearchV6').oninput=e=>{documentSearch=e.target.value.toLowerCase();renderDocuments()};q('#documentStatusV6').onchange=e=>{documentStatus=e.target.value;renderDocuments()};qa('[data-open-quote]',q('#documentGridV6')).forEach(x=>x.onclick=()=>openQuoteDialog());qa('[data-rebuild-quote]').forEach(x=>x.onclick=()=>{const old=quotes.find(qt=>qt.id===x.dataset.rebuildQuote)||{},c=invoiceClient(old);openQuoteDialog({nom:c.nom,telephone:c.telephone,email:c.email,adresse:c.adresse,code_postal:c.code_postal,ville:c.ville,objet:old.objet||''})});bindDocumentActions()}\nfunction amountForInvoice(quote,type){const total=Number(quote.total_ttc||0),pct=Number(quote.acompte_pct||30);if(type==='acompte')return total*pct/100;if(type==='solde'){const prior=invoices.filter(x=>x.devis_id===quote.id&&x.type_facture==='acompte'&&!isCancelled(x)).reduce((s,x)=>s+Number(x.total_ttc||0),0);return Math.max(0,total-prior)}return total}\nfunction verifiedInvoiceResult(result,verified){const invoice={...(verified.facture||result.facture||{}),client:verified.client||invoiceClient(result.facture||{})};const index=invoices.findIndex(x=>x.id===invoice.id);if(index>=0)invoices[index]=invoice;else invoices.unshift(invoice);return invoice}\nopenInvoiceDialog=function(devisId){const quote=quotes.find(x=>x.id===devisId)||{};if(!quoteIsComplete(quote)){toast('Ce devis est incomplet : ajoutez des lignes et un montant avant de facturer.',false);return}dialogTitle.textContent='Transformer le devis en facture';const simple=amountForInvoice(quote,'simple'),deposit=amountForInvoice(quote,'acompte'),balance=amountForInvoice(quote,'solde');dialogBody.innerHTML='';q('[data-close]',dialogBody).onclick=closeDialog;q('#invoiceFormV6').onsubmit=async event=>{event.preventDefault();const form=event.currentTarget,button=q('[type=submit]',form),proof=q('#invoiceProofV6'),popup=pendingDocument();button.disabled=true;proof.innerHTML='

Création puis vérification directe dans Supabase…

';try{const payload=Object.fromEntries(new FormData(form).entries());payload.devis_id=devisId;const result=await action('invoice.from_quote',payload,false);if(!result.facture?.id)throw new Error(result.error||'La base n’a retourné aucune facture');const verified=await action('invoice.get',{id:result.facture.id},false);if(!verified.facture||verified.facture.id!==result.facture.id)throw new Error('La facture n’a pas pu être relue après création');const invoice=verifiedInvoiceResult(result,verified);proof.innerHTML='

✓

Facture enregistrée et relue

La création est confirmée par une seconde lecture indépendante.

Numéro'+esc(invoice.numero)+'

Montant'+money(invoice.total_ttc)+'

Stockagefactures

';revealDocument(popup,'invoice',invoice.id);q('[data-open-created]',proof).onclick=()=>openDoc('invoice',invoice.id);q('[data-see-invoices]',proof).onclick=()=>{dialog.close();documentTab='invoices';showView('documents');renderDocuments()};documentTab='invoices';renderDocuments();toast(result.created===false?'Facture existante retrouvée':'Facture créée et vérifiée')}catch(error){if(popup)popup.close();proof.innerHTML='

Échec : '+esc(error.message)+'

';toast(error.message,false);button.disabled=false}};dialog.showModal()}\nopenPaymentDialog=function(id){const invoice=invoices.find(x=>x.id===id)||{};dialogTitle.textContent='Enregistrer un encaissement';dialogBody.innerHTML='';q('[data-close]',dialogBody).onclick=closeDialog;q('#paymentFormV6').onsubmit=async event=>{event.preventDefault();const button=q('[type=submit]',event.currentTarget),payload=Object.fromEntries(new FormData(event.currentTarget).entries()),proof=q('#paymentProofV6');payload.id=id;button.disabled=true;proof.innerHTML='

Enregistrement du paiement…

';try{await action('invoice.mark_paid',payload,false);const verified=await action('invoice.get',{id},false);if(!verified.facture||!isPaid(verified.facture))throw new Error('Le paiement n’a pas été confirmé après relecture');verifiedInvoiceResult({facture:verified.facture},verified);proof.innerHTML='

✓

Paiement confirmé

Le statut payé a été relu dans la base.

';renderDocuments();renderPilot();toast('Paiement enregistré et vérifié')}catch(error){proof.innerHTML='

'+esc(error.message)+'

';toast(error.message,false);button.disabled=false}};dialog.showModal()}\nrenderDocuments();\n`;\n",[],[448,621],"97d72f08-1f90-42cd-b316-4911e9c61b59","client-v5.ts","019f66f6-e506-776c-9df7-5be174abebe5",["D",1784138884418],"export const CLIENT_V5 = String.raw`\nconst pools=list(data.piscines);\nconst friendlyErrors={action_failed:'Action impossible.',upstream_400:'Données incomplètes ou invalides.',upstream_409:'Cette action existe déjà ou entre en conflit.',upstream_500:'Le service métier a rencontré une erreur.',invalid_id:'Identifiant invalide.',missing_required_fields:'Informations obligatoires manquantes.',unsupported_action:'Action non disponible.',csrf_rejected:'Session expirée. Rechargez la page.'};\nfunction friendlyError(value){const key=String(value||'action_failed');return friendlyErrors[key]||key.replaceAll('_',' ')}\naction=async function(actionName,payload={},reload=true){let response,result={},raw='';try{response=await fetch('/api/action',{method:'POST',headers:{'content-type':'application/json','x-csrf-token':csrf},body:JSON.stringify({action:actionName,data:payload})});raw=await response.text();try{result=raw?JSON.parse(raw):{}}catch{throw new Error('Réponse métier illisible.')}if(!response.ok||result.ok===false)throw new Error(friendlyError(result.message||result.error||('upstream_'+response.status)));toast(result.message||'Action exécutée et enregistrée.');if(reload)setTimeout(()=>location.reload(),950);return result}catch(error){throw new Error(error instanceof Error?friendlyError(error.message):'Action impossible.')}};\nfunction pendingDocument(){const win=window.open('about:blank','_blank');if(win){win.document.open();win.document.write('Préparation du documentPréparation du document…');win.document.close()}return win}\nfunction revealDocument(win,kind,id){const url='/documents/'+(kind==='quote'?'devis':'facture')+'/'+encodeURIComponent(id);if(win)win.location.href=url;else window.open(url,'_blank','noopener')}\nfunction entityClient(entity){if(entity?.client?.id)return entity.client;const id=entity?.client_id||entity?.client?.id;return clients.find(c=>c.id===id)||entity?.client||null}\nfunction clientPhone(entity){return entityClient(entity)?.telephone||entity?.telephone||entity?.customer_phone||''}\nfunction clientAddress(entity){const c=entityClient(entity)||{};return entity?.adresse||[c.adresse,c.code_postal,c.ville].filter(Boolean).join(' ')||''}\nfunction related(collection,clientId){return collection.filter(x=>(x.client_id||x.client?.id)===clientId)}\nfunction scoreRequest(req){const c=entityClient(req)||{},pool=pools.find(p=>p.client_id===c.id),checks=[c.nom,c.telephone,c.ville||c.adresse,req.description||req.objet,pool?.type_bassin];const complete=checks.filter(present).length;return{score:Math.round(complete/checks.length*100),missing:['nom','téléphone','adresse ou ville','description','type de bassin'].filter((_,i)=>!present(checks[i]))}}\nfunction suggestedLines(req){const text=String(req?.description||req?.objet||'').toLowerCase(),groups=[['fuite',['fuite','diagnostic']],['eau verte',['traitement','remise en route']],['filtration',['filtration','pompe','filtre']],['entretien',['entretien']],['hivernage',['hivernage']],['chauffage',['chauffage','pompe à chaleur']],['liner',['liner','étanchéité']]],terms=[];for(const [needle,words] of groups)if(text.includes(needle))terms.push(...words);const found=[];for(const item of catalog){const label=String(item.designation||'').toLowerCase();if(terms.some(t=>label.includes(t))&&!found.some(x=>x.designation===item.designation))found.push(item)}return found.slice(0,4)}\nfunction setForm(form,prefill={}){for(const [key,value] of Object.entries(prefill)){const field=q('[name=\"'+key+'\"]',form);if(!field||value===undefined||value===null)continue;if(field.type==='checkbox')field.checked=Boolean(value);else field.value=String(value)}}\nfunction dialogProof(message,ok=true){return '

'+esc(message)+'

'}\nconst baseOpenSimple=openSimple;\nopenSimple=function(kind,prefill={}){baseOpenSimple(kind);const form=q('#actionForm',dialogBody);if(!form)return;setForm(form,prefill);if(kind==='availability'){form.onsubmit=async event=>{event.preventDefault();const button=q('[type=submit]',form),payload=Object.fromEntries(new FormData(form).entries()),box=q('#actionResult');button.disabled=true;box.classList.add('show');box.textContent='Recherche du meilleur créneau…';try{const result=await action('availability.check',payload,false),slot=result.available_slot||result.slot||'';box.innerHTML=dialogProof(result.message||'Recherche terminée.',Boolean(result.available));if(slot){const next=document.createElement('div');next.className='next-step';next.innerHTML='Créneau disponible

'+esc(dt(slot))+'

';q('button',next).onclick=()=>{dialog.close();openSimple('appointment',{telephone:prefill.telephone||'',date_heure:String(slot).slice(0,16),adresse:prefill.adresse||'',type:prefill.type||'Intervention'})};box.appendChild(next)}button.disabled=false}catch(error){box.innerHTML=dialogProof(error.message,false);button.disabled=false}}}};\nconst baseOpenQuoteDialog=openQuoteDialog;\nopenQuoteDialog=function(prefill={}){baseOpenQuoteDialog();const form=q('#quoteForm',dialogBody);if(!form)return;setForm(form,prefill);const suggestions=Array.isArray(prefill.lines)?prefill.lines:[];if(suggestions.length){q('#quoteLines').innerHTML='';suggestions.forEach(line=>quoteLine(line))}updateQuoteTotals();form.onsubmit=async event=>{event.preventDefault();const button=q('[type=submit]',form),popup=pendingDocument(),payload=Object.fromEntries(new FormData(form).entries());payload.lines=qa('.quote-line',form).map(row=>({type_ligne:q('[name=type_ligne]',row).value,designation:q('[name=designation]',row).value,quantite:Number(q('[name=quantite]',row).value||1),unite:q('[name=unite]',row).value,prix_unitaire_ht:Number(q('[name=prix_unitaire_ht]',row).value||0),tva_taux:Number(q('[name=tva_taux]',row).value||20)}));button.disabled=true;try{const result=await action('quote.create',payload,false);dialog.close();if(result.devis?.id)revealDocument(popup,'quote',result.devis.id);else if(popup)popup.close();setTimeout(()=>location.reload(),1200)}catch(error){if(popup)popup.close();toast(error.message,false);button.disabled=false}}};\nqa('[data-open-quote]').forEach(button=>button.onclick=()=>openQuoteDialog());\nconst baseOpenInvoiceDialog=openInvoiceDialog;\nopenInvoiceDialog=function(devisId){baseOpenInvoiceDialog(devisId);const form=q('#invoiceForm',dialogBody);if(!form)return;form.onsubmit=async event=>{event.preventDefault();const button=q('[type=submit]',form),popup=pendingDocument(),payload=Object.fromEntries(new FormData(form).entries());payload.devis_id=devisId;button.disabled=true;try{const result=await action('invoice.from_quote',payload,false);dialog.close();if(result.facture?.id)revealDocument(popup,'invoice',result.facture.id);else if(popup)popup.close();setTimeout(()=>location.reload(),1200)}catch(error){if(popup)popup.close();toast(error.message,false);button.disabled=false}}};\nopenPaymentDialog=function(id){const invoice=invoices.find(x=>x.id===id)||{};dialogTitle.textContent='Enregistrer un encaissement';dialogBody.innerHTML='';q('[data-close]',dialogBody).onclick=closeDialog;q('#paymentForm').onsubmit=async event=>{event.preventDefault();const button=q('[type=submit]',event.currentTarget),payload=Object.fromEntries(new FormData(event.currentTarget).entries());payload.id=id;button.disabled=true;try{await action('invoice.mark_paid',payload)}catch(error){toast(error.message,false);button.disabled=false}};dialog.showModal()};\nfunction openClient360(id){const c=clients.find(x=>x.id===id);if(!c)return;const reqs=related(requests,id),qs=related(quotes,id),ins=related(invoices,id),rdvs=related(appointments,id),ps=pools.filter(x=>x.client_id===id);dialogTitle.textContent=c.nom||c.telephone||'Client';dialogBody.innerHTML='

Demandes'+reqs.length+'

Devis'+qs.length+'

À encaisser'+money(ins.filter(x=>!isPaid(x)).reduce((s,x)=>s+Number(x.total_ttc||0),0))+'

Coordonnées

'+esc([c.telephone,c.email,[c.adresse,c.code_postal,c.ville].filter(Boolean).join(' ')].filter(Boolean).join(' · '))+'

'+(ps.length?'

Piscine : '+esc(ps.map(p=>p.type_bassin||p.volume_m3||'bassin').join(', '))+'

':'')+'

Historique récent

'+[...reqs.slice(0,3).map(x=>'

'+esc(x.objet||'Demande')+'

'+esc(textStatus(x.statut))+' · '+dt(x.created_at)+'

'),...qs.slice(0,2).map(x=>'

'+esc(x.numero||'Devis')+'

'+money(x.total_ttc)+' · '+esc(textStatus(x.statut))+'

')].join('')+'

';qa('[data-client-doc]',dialogBody).forEach(x=>x.onclick=()=>openDoc('quote',x.dataset.clientDoc));q('[data-client-quote]',dialogBody).onclick=()=>{dialog.close();openQuoteDialog({nom:c.nom,telephone:c.telephone,email:c.email,adresse:c.adresse,code_postal:c.code_postal,ville:c.ville})};q('[data-client-rdv]',dialogBody).onclick=()=>{dialog.close();openSimple('appointment',{telephone:c.telephone,adresse:[c.adresse,c.code_postal,c.ville].filter(Boolean).join(' ')})};q('[data-next-action]',dialogBody).onclick=async event=>{event.currentTarget.disabled=true;const target=q('#clientNext');target.innerHTML='

Analyse du dossier…

';try{const result=await action('next.action',{telephone:c.telephone},false);target.innerHTML='

'+esc(result.assistant_message||'Prochaine action')+'

'+esc((result.reason_codes||[]).join(', '))+'

'}catch(error){target.innerHTML=dialogProof(error.message,false);event.currentTarget.disabled=false}};dialog.showModal()}\nfunction openRequestFlow(id){const req=requests.find(x=>x.id===id);if(!req)return;const c=entityClient(req)||{},quality=scoreRequest(req),suggestions=suggestedLines(req);dialogTitle.textContent=req.objet||'Demande client';dialogBody.innerHTML='

=80?'high':quality.score>=50?'mid':'low')+'\">'+quality.score+'%

Dossier '+(quality.score>=80?'exploitable':'à compléter')+'

'+(quality.missing.length?'Manque : '+esc(quality.missing.join(', ')):'Toutes les informations essentielles sont présentes.')+'

Besoin

'+esc(req.description||req.objet||'Non renseigné')+'

'+esc(c.nom||c.telephone||'Client inconnu')+' · '+esc(textStatus(req.urgence||'normale'))+' · '+esc(textStatus(req.statut||'nouveau'))+'

'+(suggestions.length?'

Préparation de devis suggérée

'+esc(suggestions.map(x=>x.designation).join(' · '))+'

':'')+'

';q('[data-request-task]',dialogBody).onclick=async event=>{event.currentTarget.disabled=true;try{await action('task.create',{type_tache:'rappeler',priorite:urgent(req)?'haute':'normale',titre:'Rappeler '+(c.nom||c.telephone||'le client'),description:req.description||req.objet||'',client_id:c.id||null})}catch(error){toast(error.message,false);event.currentTarget.disabled=false}};q('[data-request-rdv]',dialogBody).onclick=()=>{dialog.close();openSimple('availability',{telephone:c.telephone||'',adresse:clientAddress(req),type:req.objet||'Intervention'})};q('[data-request-quote]',dialogBody).onclick=()=>{dialog.close();openQuoteDialog({nom:c.nom,telephone:c.telephone,email:c.email,adresse:c.adresse,code_postal:c.code_postal,ville:c.ville,objet:req.description||req.objet||'',lines:suggestions})};dialog.showModal()}\nfunction openAppointmentBrief(id){const rdv=appointments.find(x=>x.id===id);if(!rdv)return;const c=entityClient(rdv)||{},address=clientAddress(rdv);dialogTitle.textContent='Briefing intervention';dialogBody.innerHTML='

Client'+esc(c.nom||c.telephone||'À identifier')+'

Horaire'+esc(dt(rdv.date_heure))+'

Durée'+esc(rdv.duree_min||60)+' min

Mission

'+esc(rdv.type_rdv||rdv.objet||'Intervention')+'

'+esc(address||'Adresse à confirmer')+'

'+(address?'':'')+'

';if(q('[data-map]',dialogBody))q('[data-map]',dialogBody).onclick=()=>window.open('https://www.google.com/maps/search/?api=1&query='+encodeURIComponent(address),'_blank','noopener');q('[data-brief-client]',dialogBody).onclick=()=>{dialog.close();if(c.id)openClient360(c.id)};q('[data-brief-task]',dialogBody).onclick=async event=>{event.currentTarget.disabled=true;try{await action('task.create',{type_tache:'preparer_intervention',priorite:'normale',titre:'Préparer '+(rdv.type_rdv||'intervention')+' — '+(c.nom||c.telephone||''),description:address+' · '+dt(rdv.date_heure),client_id:c.id||null})}catch(error){toast(error.message,false);event.currentTarget.disabled=false}};dialog.showModal()}\nfunction openPurchaseReview(id){const purchase=purchases.find(x=>x.id===id);if(!purchase)return;dialogTitle.textContent='Contrôle achat fournisseur';dialogBody.innerHTML='

Fournisseur'+esc(purchase.fournisseur||'À identifier')+'

Montant'+money(purchase.total_ttc)+'

OCR'+esc(textStatus(purchase.ocr_statut||'en attente'))+'

Facture '+esc(purchase.numero_facture||'sans numéro')+' · '+dateOnly(purchase.date_facture||purchase.created_at)+'

';q('[data-purchase-task]',dialogBody).onclick=async event=>{event.currentTarget.disabled=true;try{await action('task.create',{type_tache:'valider_facture_achat',priorite:'normale',titre:'Contrôler facture '+(purchase.numero_facture||purchase.fournisseur||''),description:(purchase.fournisseur||'')+' · '+money(purchase.total_ttc)})}catch(error){toast(error.message,false);event.currentTarget.disabled=false}};dialog.showModal()}\nrenderRequests=function(){const term=(q('#requestSearch')?.value||'').toLowerCase(),filter=q('#requestFilter')?.value||'all',rows=requests.filter(x=>{const hay=JSON.stringify([x.numero,x.objet,x.description,clientName(x)]).toLowerCase();return(!term||hay.includes(term))&&(filter==='all'||(filter==='urgent'?urgent(x):String(x.statut||'')===filter))});const head=q('#view-requests thead tr');if(head&&!head.querySelector('[data-actions-head]'))head.insertAdjacentHTML('beforeend','');q('#requestsBody').innerHTML=rows.length?rows.map(x=>''+esc(x.objet||'Demande')+'

'+esc(clientName(x))+'

'+pill(x.urgence||'normale')+''+pill(x.statut||'nouveau')+''+esc(x.description||'—')+''+dt(x.created_at)+'').join(''):'Aucune demande';q('#requestsMobile').innerHTML=rows.map(x=>'

'+esc(x.objet||'Demande')+'

'+esc(clientName(x))+' · '+dt(x.created_at)+'

'+pill(x.statut||'nouveau')+'

').join('')||'

Aucune demande

';qa('[data-request-open]').forEach(x=>x.onclick=()=>openRequestFlow(x.dataset.requestOpen));q('#requestCount').textContent=rows.length};q('#requestSearch').oninput=renderRequests;q('#requestFilter').onchange=renderRequests;\nrenderClients=function(){const head=q('#view-clients thead tr');if(head&&!head.querySelector('[data-actions-head]'))head.insertAdjacentHTML('beforeend','');q('#clientsBody').innerHTML=clients.length?clients.map(x=>''+esc(x.nom||'Sans nom')+'

'+esc(x.ville||'')+'

'+esc(x.telephone||'—')+''+esc(x.email||'—')+''+pill(x.vip?'VIP':'actif')+'').join(''):'Aucun client';q('#clientsMobile').innerHTML=clients.map(x=>'

'+esc(x.nom||x.telephone||'Client')+'

'+esc([x.telephone,x.email].filter(Boolean).join(' · '))+'

').join('')||'

Aucun client

';qa('[data-client-open]').forEach(x=>x.onclick=()=>openClient360(x.dataset.clientOpen));q('#clientCount').textContent=clients.length};\nrenderAgenda=function(){const rows=[...appointments].sort((a,b)=>new Date(a.date_heure||0)-new Date(b.date_heure||0));q('#agendaList').innerHTML=rows.length?rows.map(x=>'

'+esc(clientName(x))+'

'+esc(x.type_rdv||x.objet||'Intervention')+' · '+esc(x.adresse||'Adresse non renseignée')+'

'+dt(x.date_heure)+'
'+pill(x.statut||'planifie')+'

').join(''):'

Aucun rendez-vous

';qa('[data-rdv-open]').forEach(x=>x.onclick=()=>openAppointmentBrief(x.dataset.rdvOpen))};\nconst baseQuoteRows=quoteRows,baseInvoiceRows=invoiceRows;\npurchaseRows=function(){return purchases.map(x=>''+esc(x.numero_facture||x.fournisseur||'Achat')+'

'+esc(x.fournisseur||'Fournisseur')+'

'+dateOnly(x.date_facture||x.created_at)+''+money(x.total_ttc)+''+pill(x.ocr_statut||'en_attente')+'').join('')};\nrenderDocuments=function(){qa('[data-document-tab]').forEach(x=>x.classList.toggle('active',x.dataset.documentTab===documentTab));const body=documentTab==='quotes'?baseQuoteRows():documentTab==='invoices'?baseInvoiceRows():purchaseRows();q('#documentsBody').innerHTML=body||'Aucun document';let mobile=q('#documentsMobile');if(!mobile){mobile=document.createElement('ul');mobile.id='documentsMobile';mobile.className='list mobile-docs';q('#documentsBody').closest('.card').appendChild(mobile)}const rows=documentTab==='quotes'?quotes.map(x=>'

'+esc(x.numero||'Devis')+'

'+esc(clientName(x))+' · '+money(x.total_ttc)+'

'+(!invoices.some(f=>f.devis_id===x.id)&&!/(refuse|expire)/i.test(x.statut||'')?'':'')+'

'+pill(x.statut||'brouillon')+'

'):documentTab==='invoices'?invoices.map(x=>'

'+esc(x.numero||'Facture')+'

'+esc(clientName(x))+' · '+money(x.total_ttc)+'

'+(!isPaid(x)&&!isCancelled(x)?'':'')+'

'+pill(x.statut||'brouillon')+'

'):purchases.map(x=>'

'+esc(x.numero_facture||x.fournisseur||'Achat')+'

'+money(x.total_ttc)+'

'+pill(x.ocr_statut||'en_attente')+'

');mobile.innerHTML=rows.join('')||'

Aucun document

';bindDocumentActions();qa('[data-purchase-open]').forEach(x=>x.onclick=()=>openPurchaseReview(x.dataset.purchaseOpen))};qa('[data-document-tab]').forEach(x=>x.onclick=()=>{documentTab=x.dataset.documentTab;renderDocuments()});\nconst baseRenderToday=renderToday;renderToday=function(){baseRenderToday();const listEl=q('#priorityList'),urgentRows=requests.filter(x=>urgent(x)&&!/(termine|annule|ferme)/i.test(x.statut||'')).slice(0,4),late=invoices.filter(x=>!isPaid(x)&&!isCancelled(x)&&x.date_echeance&&new Date(x.date_echeance)'

'+esc(x.objet||x.description||'Demande urgente')+'

'+esc(clientName(x))+'

'),...late.map(x=>'

Facture '+esc(x.numero||'')+' en retard

'+esc(clientName(x))+' · '+money(x.total_ttc)+'

')].join('')||'

Aucune priorité critique

La file du jour est maîtrisée.

';qa('[data-request-open]',listEl).forEach(x=>x.onclick=()=>openRequestFlow(x.dataset.requestOpen));qa('[data-mark-paid]',listEl).forEach(x=>x.onclick=()=>openPaymentDialog(x.dataset.markPaid))};\nconst baseRenderPilot=renderPilot;renderPilot=function(){baseRenderPilot();const incomplete=requests.filter(x=>scoreRequest(x).score<80&&!/(termine|annule|ferme)/i.test(x.statut||'')),pipeline=quotes.filter(x=>/(brouillon|pret|envoye|accepte)/i.test(x.statut||'')).reduce((s,x)=>s+Number(x.total_ttc||0),0);q('#pilotInsights').insertAdjacentHTML('beforeend','

Dossiers incomplets'+incomplete.length+'

Pipeline devis'+money(pipeline)+'

');const center=q('#actionCenter');incomplete.slice(0,3).forEach(x=>center.insertAdjacentHTML('beforeend','

Compléter '+esc(clientName(x))+'

'+scoreRequest(x).score+' % du dossier renseigné

'));qa('[data-request-open]',center).forEach(x=>x.onclick=()=>openRequestFlow(x.dataset.requestOpen))};\nconst baseRenderSettings=renderSettings;renderSettings=function(){baseRenderSettings();const missing=configMissing(),host=q('#blockerList').parentElement;if(missing.length&&!q('#settingsTask')){const actions=document.createElement('div');actions.className='actions mt16';actions.innerHTML='';host.insertBefore(actions,host.querySelector('.actions.mt16'));q('#settingsTask').onclick=async event=>{event.currentTarget.disabled=true;try{await action('task.create',{type_tache:'configuration',priorite:'haute',titre:'Compléter les informations entreprise',description:'Champs manquants : '+missing.join(', ')})}catch(error){toast(error.message,false);event.currentTarget.disabled=false}};q('#copySettings').onclick=async()=>{await navigator.clipboard.writeText('Informations à compléter : '+missing.join(', '));toast('Checklist copiée.')}}};\nrenderSearch=function(term){term=term.toLowerCase().trim();const source=[...requests.map(x=>({type:'request',id:x.id,title:x.objet||'Demande',sub:clientName(x)+' · '+textStatus(x.statut)})),...clients.map(x=>({type:'client',id:x.id,title:x.nom||x.telephone||'Client',sub:[x.telephone,x.email].filter(Boolean).join(' · ')})),...quotes.map(x=>({type:'quote',id:x.id,title:x.numero||x.objet||'Devis',sub:clientName(x)+' · '+money(x.total_ttc)})),...invoices.map(x=>({type:'invoice',id:x.id,title:x.numero||'Facture',sub:clientName(x)+' · '+money(x.total_ttc)}))].filter(x=>!term||(x.title+' '+x.sub).toLowerCase().includes(term)).slice(0,20);searchResults.innerHTML=source.length?source.map((x,i)=>'').join(''):'

Aucun résultat

';qa('[data-result]',searchResults).forEach(x=>x.onclick=()=>{const item=source[Number(x.dataset.result)];searchDialog.close();if(item.type==='request')openRequestFlow(item.id);else if(item.type==='client')openClient360(item.id);else openDoc(item.type,item.id)})};\nrenderToday();renderRequests();renderAgenda();renderClients();renderDocuments();renderPilot();renderSettings();\n`;",[],[448,628],"b22e7781-2bf4-4bf1-b711-61ed5fa081b1","client-v10.ts","019f66f6-e506-776c-9df7-548a8ef5551f",["D",1784138884418],"export const CSS_V10 = String.raw`\n.v10-sync{display:inline-flex;align-items:center;gap:7px;color:var(--muted);font-size:12px}.v10-sync i{width:8px;height:8px;border-radius:50%;background:var(--accent);box-shadow:0 0 0 4px rgba(53,209,181,.1)}\n.v10-pager{display:flex;align-items:center;justify-content:center;gap:12px;padding:16px 18px;border-top:1px solid var(--line);color:var(--muted);font-size:12px}.v10-pager[hidden]{display:none}.v10-pager .btn{min-width:138px}.v10-pager strong{color:var(--ink)}\n.v10-loading{position:relative;min-height:150px}.v10-loading:after{content:'Chargement des données…';position:absolute;inset:0;z-index:15;display:grid;place-items:center;background:rgba(9,16,23,.72);backdrop-filter:blur(3px);color:var(--ink);font-weight:800;border-radius:16px}\n.v10-client-toolbar{margin-bottom:14px}.v10-client-toolbar .field{margin:0;flex:1}.v10-client-toolbar input{width:min(460px,100%)}\n.v10-data-note{display:flex;align-items:center;gap:7px;color:var(--muted);font-size:11px}.v10-data-note:before{content:'';width:7px;height:7px;border-radius:50%;background:var(--ok)}.v10-data-note.loading:before{background:var(--warn)}.v10-data-note.bad:before{background:var(--danger)}\n@media(max-width:700px){.v10-pager{flex-direction:column}.v10-pager .btn{width:100%}.v10-client-toolbar{align-items:stretch}.v10-client-toolbar input{width:100%}}\n`;\n\nexport const CLIENT_V10 = String.raw`\nconst v10State={\n requests:{loaded:false,loading:false,total:Number(data.counts?.demandes||requests.length),next:null,search:'',status:'all'},\n clients:{loaded:false,loading:false,total:Number(data.counts?.clients||clients.length),next:null,search:''},\n appointments:{loaded:false,loading:false,total:Number(data.counts?.rendez_vous||appointments.length),next:null},\n quotes:{loaded:false,loading:false,total:Number(data.counts?.devis||quotes.length),next:null,search:'',status:'all'},\n invoices:{loaded:false,loading:false,total:Number(data.counts?.factures||invoices.length),next:null,search:'',status:'all'},\n purchases:{loaded:false,loading:false,total:Number(data.counts?.achats||purchases.length),next:null,search:'',status:'all'}\n};\nconst v10Targets={requests,clients,appointments,quotes,invoices,purchases};\nconst v10Actions={requests:'requests.list',clients:'clients.list',appointments:'appointments.list',quotes:'documents.list',invoices:'documents.list',purchases:'documents.list'};\nconst v10Views={requests:'view-requests',clients:'view-clients',appointments:'view-agenda',quotes:'view-documents',invoices:'view-documents',purchases:'view-documents'};\nlet v10SearchTimer=0;\nfunction v10Replace(target,items,append){if(!append)target.splice(0,target.length);const known=new Set(target.map(x=>x&&x.id).filter(Boolean));for(const item of list(items)){if(!item?.id||!known.has(item.id)){target.push(item);if(item?.id)known.add(item.id)}}}\nasync function v10Read(resource,params={}){const query=new URLSearchParams();for(const [key,value] of Object.entries(params))if(value!==null&&value!==undefined&&value!=='')query.set(key,String(value));const response=await fetch('/api/data/'+resource+(query.size?'?'+query.toString():''),{headers:{accept:'application/json'}});const result=await response.json();if(!response.ok||result.ok===false)throw new Error(result.error||'lecture_indisponible');return result}\nlet v10SnapshotLoaded=!data.deferred_business,v10SnapshotPromise=null;\nfunction v10ApplySnapshot(result){data.deferred_business=false;data.snapshot_error=false;data.mode=result.mode||'progressive';data.counts=result.counts||{};data.integrations=result.integrations||{};const nextSettings=result.settings||{};Object.assign(company,nextSettings.entreprise||{});Object.assign(settings,nextSettings,{entreprise:company});v10Replace(clients,result.clients,false);v10Replace(pools,result.piscines,false);v10Replace(requests,result.demandes,false);v10Replace(appointments,result.rendez_vous,false);v10Replace(quotes,result.devis,false);v10Replace(invoices,result.factures,false);v10Replace(purchases,result.achats,false);v10Replace(tasks,result.taches,false);v10Replace(catalog,result.catalogue,false);const totals=data.counts||{};v10State.requests.total=Number(totals.demandes||requests.length);v10State.clients.total=Number(totals.clients||clients.length);v10State.appointments.total=Number(totals.rendez_vous||appointments.length);v10State.quotes.total=Number(totals.devis||quotes.length);v10State.invoices.total=Number(totals.factures||invoices.length);v10State.purchases.total=Number(totals.achats||purchases.length);for(const state of Object.values(v10State)){state.loaded=false;state.next=null}v10SnapshotLoaded=true;renderToday();renderRequests();renderAgenda();renderClients();renderDocuments();renderPilot();renderSettings();v10Decorate()}\nasync function v10LoadSnapshot(){if(v10SnapshotLoaded)return;if(v10SnapshotPromise)return v10SnapshotPromise;const surface=q('#content')||q('.view.active')||q('#view-today');surface?.classList.add('v10-loading');surface?.setAttribute('aria-busy','true');v10SnapshotPromise=(async()=>{const result=await v10Read('snapshot');v10ApplySnapshot(result)})();try{await v10SnapshotPromise}catch(error){data.snapshot_error=true;v10Decorate();toast('Synchronisation métier indisponible : '+error.message,false)}finally{v10SnapshotPromise=null;surface?.classList.remove('v10-loading');surface?.setAttribute('aria-busy','false')}}\nfunction v10Busy(key,on){const id=v10Views[key],view=id?q('#'+id):null;if(view){view.classList.toggle('v10-loading',on);view.setAttribute('aria-busy',on?'true':'false')}}\nasync function v10Load(key,{append=false,search,status}={}){const state=v10State[key];if(!state||state.loading)return;state.loading=true;v10Busy(key,true);try{const params={limit:100,offset:append?(state.next??v10Targets[key].length):0};if(key==='requests'){params.search=search??state.search;params.status=status??state.status}if(key==='clients')params.search=search??state.search;if(key==='appointments'){const from=new Date(Date.now()-30*86400000),to=new Date(Date.now()+400*86400000);params.from=from.toISOString();params.to=to.toISOString()}if(['quotes','invoices','purchases'].includes(key)){params.kind=key;params.search=search??state.search;params.status=status??state.status}const result=await v10Read(key==='appointments'?'appointments':key==='requests'?'requests':key==='clients'?'clients':'documents',params);v10Replace(v10Targets[key],result.items,append);state.loaded=true;state.total=Number(result.total||0);state.next=result.next_offset===null||result.next_offset===undefined?null:Number(result.next_offset);if(search!==undefined)state.search=search;if(status!==undefined)state.status=status;v10RenderKey(key)}catch(error){toast('Données conservées : '+error.message,false)}finally{state.loading=false;v10Busy(key,false);v10Decorate()}}\nfunction v10RenderKey(key){if(key==='requests')renderRequests();else if(key==='clients')renderClients();else if(key==='appointments'){renderAgenda();renderToday()}else if(['quotes','invoices','purchases'].includes(key)){renderDocuments();renderPilot()}}\nfunction v10Pager(key){const state=v10State[key],view=q('#'+v10Views[key]);if(!state||!view)return;let host=q('[data-v10-pager=\"'+key+'\"]',view);if(!host){host=document.createElement('div');host.dataset.v10Pager=key;host.className='v10-pager';const target=key==='requests'?q('#requestsBody')?.closest('article.card'):key==='clients'?q('#clientsBody')?.closest('article.card'):key==='appointments'?q('#agendaList')?.closest('article.card'):q('#documentsWorkspace')||q('#documentsBody')?.closest('article.card');if(target)target.appendChild(host)}if(!host)return;const shown=v10Targets[key].length;host.hidden=state.next===null;host.innerHTML=''+esc(Math.min(shown,state.total))+' sur '+esc(state.total)+' affichés';q('button',host).onclick=()=>v10Load(key,{append:true})}\nfunction v10Decorate(){if(q('#requestCount'))q('#requestCount').textContent=data.deferred_business?'—':String(v10State.requests.total);if(q('#clientCount'))q('#clientCount').textContent=data.deferred_business?'—':String(v10State.clients.total);const note=q('#view-today .hero .v10-data-note')||document.createElement('span');note.className='v10-data-note'+(data.snapshot_error?' bad':data.deferred_business?' loading':'');note.textContent=data.snapshot_error?'Données métier indisponibles':data.deferred_business?'Synchronisation métier en cours':data.mode==='progressive'?'Chargement progressif actif':'Données synchronisées';if(!note.parentNode)q('#view-today .hero')?.appendChild(note);v10Pager('requests');v10Pager('clients');v10Pager('appointments');const active=documentTab==='quotes'?'quotes':documentTab==='invoices'?'invoices':'purchases';v10Pager(active)}\nconst v10RenderRequestsBase=renderRequests;renderRequests=function(){v10RenderRequestsBase();v10Decorate()};\nconst v10RenderClientsBase=renderClients;renderClients=function(){v10RenderClientsBase();v10Decorate()};\nconst v10RenderAgendaBase=renderAgenda;renderAgenda=function(){v10RenderAgendaBase();v10Decorate()};\nconst v10RenderDocumentsBase=renderDocuments;renderDocuments=function(){v10RenderDocumentsBase();v10Decorate();const input=q('#documentSearchV8');if(input){input.oninput=event=>{documentSearch=event.target.value.toLowerCase();clearTimeout(v10SearchTimer);v10SearchTimer=setTimeout(()=>{const key=documentTab==='quotes'?'quotes':documentTab==='invoices'?'invoices':'purchases';v10Load(key,{append:false,search:documentSearch})},280)}}};\nlet v10AiLoaded=!ai.deferred,v10SecurityLoaded=!data.security?.deferred,v10SupervisionPromise=null;\nasync function v10FetchJson(path){const response=await fetch(path,{headers:{accept:'application/json'}});const result=await response.json();if(!response.ok||result.ok===false)throw new Error(result.error||'supervision_indisponible');return result}\nasync function v10LoadSupervision(){if(v10AiLoaded&&v10SecurityLoaded)return;if(v10SupervisionPromise)return v10SupervisionPromise;v10SupervisionPromise=(async()=>{const [aiResult,securityResult]=await Promise.allSettled([v10FetchJson('/api/ai-supervision'),v10FetchJson('/api/security-audit')]);if(aiResult.status==='fulfilled'){Object.assign(ai,aiResult.value,{deferred:false});v10AiLoaded=true}if(securityResult.status==='fulfilled'){data.security={...securityResult.value,deferred:false};v10SecurityLoaded=true}data.supervision_degraded=!(v10AiLoaded&&v10SecurityLoaded);renderPilot();renderSettings()})();try{await v10SupervisionPromise}finally{v10SupervisionPromise=null}}\nasync function v10EnsureView(view){if(!v10SnapshotLoaded)await v10LoadSnapshot();if(view==='requests'&&!v10State.requests.loaded)await v10Load('requests');else if(view==='clients'&&!v10State.clients.loaded)await v10Load('clients');else if(view==='agenda'&&!v10State.appointments.loaded)await v10Load('appointments');else if(view==='documents'){const key=documentTab==='quotes'?'quotes':documentTab==='invoices'?'invoices':'purchases';if(!v10State[key].loaded)await v10Load(key)}else if(view==='pilot'){await Promise.all([v10State.quotes.loaded?null:v10Load('quotes'),v10State.invoices.loaded?null:v10Load('invoices'),v10State.requests.loaded?null:v10Load('requests')]);await v10LoadSupervision()}else if(view==='settings')await v10LoadSupervision()}\nconst v10ShowViewBase=showView;showView=function(view){v10ShowViewBase(view);v10EnsureView(view).catch(error=>toast(error.message,false))};\nfunction v10InstallClientSearch(){const view=q('#view-clients'),card=q('#clientsBody')?.closest('article.card');if(!view||!card||q('#clientSearchV10'))return;const toolbar=document.createElement('div');toolbar.className='toolbar v10-client-toolbar';toolbar.innerHTML='

Recherche serveur';card.before(toolbar);q('#clientSearchV10').oninput=event=>{clearTimeout(v10SearchTimer);const term=event.target.value.trim();v10SearchTimer=setTimeout(()=>v10Load('clients',{append:false,search:term}),280)}}\nv10InstallClientSearch();\nconst reqSearch=q('#requestSearch'),reqFilter=q('#requestFilter');if(reqSearch)reqSearch.oninput=()=>{clearTimeout(v10SearchTimer);v10SearchTimer=setTimeout(()=>v10Load('requests',{append:false,search:reqSearch.value.trim(),status:reqFilter?.value||'all'}),280)};if(reqFilter)reqFilter.onchange=()=>v10Load('requests',{append:false,search:reqSearch?.value.trim()||'',status:reqFilter.value});\nqa('[data-document-tab]').forEach(tab=>tab.onclick=async()=>{documentTab=tab.dataset.documentTab;v8Scope=documentTab==='quotes'?'action':documentTab==='invoices'?'open':'all';const key=documentTab==='quotes'?'quotes':documentTab==='invoices'?'invoices':'purchases';if(!v10State[key].loaded)await v10Load(key);else renderDocuments()});\nv10Decorate();v10EnsureView(location.hash.slice(1)||'today').catch(error=>toast(error.message,false));const v10IdleSupervision=()=>v10LoadSupervision().catch(()=>{});if('requestIdleCallback'in window)window.requestIdleCallback(v10IdleSupervision,{timeout:4000});else setTimeout(v10IdleSupervision,1500);\n`;\n",[],[448,635],"7e4f49c4-f056-42fe-8b70-5be1beb70ffc","business-queue.ts","019f66f6-e506-776c-9df7-503a97ee9b6b",["D",1784138884418],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nexport type QueuedBusinessAction = {\n queue_id: string;\n request_id: string;\n call_id: string;\n action: string;\n payload: Record;\n state: \"pending\" | \"processing\" | \"completed\" | \"failed\";\n attempts: number;\n created_at: string;\n next_attempt_at: string;\n};\n\nconst QUEUE_SCHEMA = `create table if not exists business_action_queue (\n queue_id text primary key,\n request_id text not null unique,\n call_id text not null,\n action text not null,\n payload_json text not null,\n state text not null default 'pending',\n attempts integer not null default 0,\n last_error text,\n created_at text not null,\n updated_at text not null,\n next_attempt_at text not null,\n completed_at text\n)`;\n\nconst QUEUEABLE_ACTIONS = new Set([\n \"update_client\",\n \"create_lead\",\n \"book_appointment\",\n \"cancel_appointment\",\n \"create_quote\",\n \"save_call_summary\",\n \"transfer_to_human\",\n]);\n\nfunction clean(value: unknown, max = 4000): string {\n return String(value ?? \"\").trim().slice(0, max);\n}\n\nasync function ensureQueue() {\n await sqlite.batch([\n QUEUE_SCHEMA,\n \"create index if not exists business_action_queue_pending_idx on business_action_queue(state,next_attempt_at,created_at)\",\n ]);\n}\n\nasync function stableRequestId(callId: string, action: string, payload: Record) {\n const stablePayload = { ...payload };\n delete stablePayload.request_id;\n const normalized = JSON.stringify(stablePayload, Object.keys(stablePayload).sort());\n const digest = await crypto.subtle.digest(\"SHA-256\", new TextEncoder().encode(normalized));\n const suffix = Array.from(new Uint8Array(digest)).slice(0, 10).map((byte) => byte.toString(16).padStart(2, \"0\")).join(\"\");\n return clean(`${callId}:${action}:${suffix}`, 240);\n}\n\nfunction queuedMessage(action: string): string {\n if (action === \"book_appointment\") {\n return \"Votre demande de créneau est bien enregistrée, mais le rendez-vous n’est pas encore confirmé. L’équipe vous rappelle pour le valider.\";\n }\n if (action === \"cancel_appointment\") {\n return \"Votre demande d’annulation est enregistrée. Elle doit encore être confirmée par l’équipe.\";\n }\n if (action === \"create_quote\") {\n return \"Votre demande de devis est enregistrée. Le devis n’est pas encore généré ni envoyé.\";\n }\n if (action === \"transfer_to_human\") {\n return \"Votre demande de rappel est bien enregistrée. Un membre de l’équipe vous recontactera.\";\n }\n if (action === \"save_call_summary\") {\n return \"Le compte rendu est sauvegardé en attente de synchronisation.\";\n }\n return \"Votre demande est bien enregistrée et sera synchronisée dès le retour du service.\";\n}\n\nexport function isQueueableBusinessAction(action: string) {\n return QUEUEABLE_ACTIONS.has(action);\n}\n\nexport async function queueBusinessAction(\n action: string,\n payload: Record,\n callId: string,\n reason: string,\n): Promise> {\n if (!isQueueableBusinessAction(action)) {\n return {\n ok: false,\n queued: false,\n action_completed: false,\n error: \"action_not_queueable\",\n safe_to_announce: true,\n assistant_message: \"Cette vérification est momentanément indisponible. L’équipe doit vous rappeler.\",\n };\n }\n await ensureQueue();\n const requestId = await stableRequestId(callId, action, payload);\n const queueId = crypto.randomUUID();\n await sqlite.execute({\n sql: `insert into business_action_queue (\n queue_id,request_id,call_id,action,payload_json,state,attempts,last_error,\n created_at,updated_at,next_attempt_at\n ) values (\n :queue_id,:request_id,:call_id,:action,:payload_json,'pending',0,:last_error,\n datetime('now'),datetime('now'),datetime('now')\n )\n on conflict(request_id) do update set\n payload_json=excluded.payload_json,\n last_error=excluded.last_error,\n updated_at=datetime('now')`,\n args: {\n queue_id: queueId,\n request_id: requestId,\n call_id: clean(callId, 240),\n action: clean(action, 80),\n payload_json: JSON.stringify(payload).slice(0, 100_000),\n last_error: clean(reason, 240),\n },\n });\n const row = await sqlite.execute({\n sql: \"select queue_id,created_at from business_action_queue where request_id=:request_id limit 1\",\n args: { request_id: requestId },\n });\n const saved = row.rows[0] as Record | undefined;\n return {\n ok: true,\n queued: true,\n queue_id: saved?.queue_id || queueId,\n queued_at: saved?.created_at || new Date().toISOString(),\n request_id: requestId,\n action,\n action_completed: action === \"save_call_summary\" || action === \"create_lead\" || action === \"update_client\" || action === \"transfer_to_human\",\n persisted_locally: true,\n synchronization_pending: true,\n requires_human: action === \"book_appointment\" || action === \"cancel_appointment\" || action === \"create_quote\",\n safe_to_announce: true,\n assistant_message: queuedMessage(action),\n };\n}\n\nexport async function businessQueueStatus() {\n await ensureQueue();\n const result = await sqlite.execute(`select\n count(*) filter(where state='pending') as pending,\n count(*) filter(where state='processing') as processing,\n count(*) filter(where state='failed') as failed,\n count(*) filter(where state='completed') as completed,\n min(created_at) filter(where state='pending') as oldest_pending\n from business_action_queue`);\n return { ok: true, ...(result.rows[0] as Record || {}) };\n}\n\nexport async function claimQueuedBusinessActions(limit = 20): Promise {\n await ensureQueue();\n const safeLimit = Math.max(1, Math.min(50, Number(limit) || 20));\n const rows = await sqlite.execute({\n sql: `select queue_id,request_id,call_id,action,payload_json,state,attempts,created_at,next_attempt_at\n from business_action_queue\n where state='pending' and next_attempt_at<=datetime('now')\n order by created_at asc limit :limit`,\n args: { limit: safeLimit },\n });\n return rows.rows.map((row: any) => ({\n ...row,\n payload: JSON.parse(String(row.payload_json || \"{}\")),\n })) as QueuedBusinessAction[];\n}\n\nexport async function completeQueuedBusinessAction(queueId: string) {\n await ensureQueue();\n await sqlite.execute({\n sql: `update business_action_queue set state='completed',completed_at=datetime('now'),\n updated_at=datetime('now'),last_error=null where queue_id=:queue_id`,\n args: { queue_id: clean(queueId, 80) },\n });\n}\n\nexport async function failQueuedBusinessAction(queueId: string, reason: string, retryAfterSeconds = 86400) {\n await ensureQueue();\n const safeDelay = Math.max(300, Math.min(604800, Number(retryAfterSeconds) || 86400));\n await sqlite.execute({\n sql: `update business_action_queue set state='pending',attempts=attempts+1,\n last_error=:last_error,updated_at=datetime('now'),\n next_attempt_at=datetime('now','+' || :delay || ' seconds')\n where queue_id=:queue_id`,\n args: { queue_id: clean(queueId, 80), last_error: clean(reason, 240), delay: safeDelay },\n });\n}\n",[],[448,642],"f352f588-8f22-4e29-b4ee-eabbbfd715cc","auth.ts","019f66f6-e505-736f-a2c2-fa632c3fe90e",["D",1784138884418],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nconst encoder = new TextEncoder();\nconst decoder = new TextDecoder();\nconst ACCESS_CODE = Deno.env.get(\"PISCINE_ACCESS_CODE\") || \"\";\nconst BRIDGE_KEY = Deno.env.get(\"PISCINE_BRIDGE_KEY\") || \"\";\nconst COOKIE = \"piscine_session\";\nconst SESSION_TTL_MS = 8 * 60 * 60 * 1000;\nconst WINDOW_MS = 5 * 60 * 1000;\nconst MAX_FAILURES = 5;\n\nexport type Session = {\n v: 2;\n iat: number;\n exp: number;\n nonce: string;\n csrf: string;\n};\n\ntype Attempt = { count: number; resetAt: number; blockedUntil: number };\nconst attempts = new Map();\nconst RATE_TABLE = \"cockpit_login_attempts\";\nlet rateTableInit: Promise | null = null;\n\nasync function ensureRateTable(): Promise {\n if (!rateTableInit) {\n rateTableInit = (async () => {\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS ${RATE_TABLE} (\n client_key TEXT PRIMARY KEY,\n failure_count INTEGER NOT NULL DEFAULT 0,\n reset_at INTEGER NOT NULL,\n blocked_until INTEGER NOT NULL DEFAULT 0,\n updated_at INTEGER NOT NULL\n )`);\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_${RATE_TABLE}_updated ON ${RATE_TABLE}(updated_at)`);\n })().catch((error) => {\n rateTableInit = null;\n throw error;\n });\n }\n return rateTableInit!;\n}\n\nfunction base64url(bytes: Uint8Array): string {\n let value = \"\";\n for (const byte of bytes) value += String.fromCharCode(byte);\n return btoa(value).replace(/\\+/g, \"-\").replace(/\\//g, \"_\").replace(/=+$/g, \"\");\n}\n\nfunction decode64url(value: string): Uint8Array {\n const padded = value.replace(/-/g, \"+\").replace(/_/g, \"/\") + \"===\".slice((value.length + 3) % 4);\n const raw = atob(padded);\n return Uint8Array.from(raw, (char) => char.charCodeAt(0));\n}\n\nfunction safeEqual(a: string, b: string): boolean {\n const aa = encoder.encode(a);\n const bb = encoder.encode(b);\n if (aa.length !== bb.length) return false;\n let diff = 0;\n for (let index = 0; index < aa.length; index++) diff |= aa[index] ^ bb[index];\n return diff === 0;\n}\n\nasync function signingKey(): Promise {\n return crypto.subtle.importKey(\n \"raw\",\n encoder.encode(`${ACCESS_CODE}\\u0000${BRIDGE_KEY}`),\n { name: \"HMAC\", hash: \"SHA-256\" },\n false,\n [\"sign\"],\n );\n}\n\nasync function signature(value: string): Promise {\n const signed = await crypto.subtle.sign(\"HMAC\", await signingKey(), encoder.encode(value));\n return base64url(new Uint8Array(signed));\n}\n\nfunction cookies(req: Request): Record {\n const result: Record = {};\n for (const chunk of (req.headers.get(\"cookie\") || \"\").split(\";\")) {\n const [rawKey, ...parts] = chunk.trim().split(\"=\");\n if (!rawKey) continue;\n try {\n result[rawKey] = decodeURIComponent(parts.join(\"=\"));\n } catch {\n result[rawKey] = \"\";\n }\n }\n return result;\n}\n\nasync function clientKey(req: Request): Promise {\n const forwarded = req.headers.get(\"cf-connecting-ip\") || req.headers.get(\"x-forwarded-for\") || \"unknown\";\n const ip = forwarded.split(\",\")[0].trim();\n const digest = await crypto.subtle.digest(\"SHA-256\", encoder.encode(`${ip}\\u0000${BRIDGE_KEY}`));\n return base64url(new Uint8Array(digest)).slice(0, 24);\n}\n\nasync function memoryAttemptFor(req: Request): Promise<[string, Attempt]> {\n const key = await clientKey(req);\n const now = Date.now();\n let state = attempts.get(key);\n if (!state || now >= state.resetAt) state = { count: 0, resetAt: now + WINDOW_MS, blockedUntil: 0 };\n attempts.set(key, state);\n return [key, state];\n}\n\nasync function persistentRetryAfter(req: Request): Promise {\n await ensureRateTable();\n const key = await clientKey(req);\n const now = Date.now();\n const result = await sqlite.execute({\n sql: `SELECT failure_count, reset_at, blocked_until FROM ${RATE_TABLE} WHERE client_key = ?`,\n args: [key],\n });\n const row = result.rows[0] as Record | undefined;\n if (!row) return 0;\n const resetAt = Number(row.reset_at || 0);\n const blockedUntil = Number(row.blocked_until || 0);\n if (now >= resetAt && now >= blockedUntil) {\n await sqlite.execute({ sql: `DELETE FROM ${RATE_TABLE} WHERE client_key = ?`, args: [key] });\n return 0;\n }\n return Math.max(0, Math.ceil((blockedUntil - now) / 1000));\n}\n\nasync function persistentRecordFailure(req: Request): Promise {\n await ensureRateTable();\n const key = await clientKey(req);\n const now = Date.now();\n const result = await sqlite.execute({\n sql: `INSERT INTO ${RATE_TABLE} (client_key, failure_count, reset_at, blocked_until, updated_at)\n VALUES (?, 1, ?, 0, ?)\n ON CONFLICT(client_key) DO UPDATE SET\n failure_count = CASE WHEN excluded.updated_at >= ${RATE_TABLE}.reset_at THEN 1 ELSE ${RATE_TABLE}.failure_count + 1 END,\n reset_at = CASE WHEN excluded.updated_at >= ${RATE_TABLE}.reset_at THEN excluded.reset_at ELSE ${RATE_TABLE}.reset_at END,\n blocked_until = CASE\n WHEN (CASE WHEN excluded.updated_at >= ${RATE_TABLE}.reset_at THEN 1 ELSE ${RATE_TABLE}.failure_count + 1 END) >= ?\n THEN excluded.updated_at + ?\n WHEN ${RATE_TABLE}.blocked_until > excluded.updated_at THEN ${RATE_TABLE}.blocked_until\n ELSE 0\n END,\n updated_at = excluded.updated_at\n RETURNING failure_count, reset_at, blocked_until`,\n args: [key, now + WINDOW_MS, now, MAX_FAILURES, WINDOW_MS],\n });\n const row = result.rows[0] as Record | undefined;\n await sqlite.execute({\n sql: `DELETE FROM ${RATE_TABLE} WHERE updated_at < ?`,\n args: [now - 7 * 24 * 60 * 60 * 1000],\n });\n return Math.max(0, Math.ceil((Number(row?.blocked_until || 0) - now) / 1000));\n}\n\nexport function authConfigured(): boolean {\n return Boolean(ACCESS_CODE && BRIDGE_KEY);\n}\n\nexport function validAccessCode(value: string): boolean {\n return Boolean(ACCESS_CODE) && safeEqual(value, ACCESS_CODE);\n}\n\nexport async function loginRetryAfter(req: Request): Promise {\n try {\n return await persistentRetryAfter(req);\n } catch {\n const [, state] = await memoryAttemptFor(req);\n return Math.max(0, Math.ceil((state.blockedUntil - Date.now()) / 1000));\n }\n}\n\nexport async function recordLoginFailure(req: Request): Promise {\n let retryAfter = 0;\n try {\n retryAfter = await persistentRecordFailure(req);\n } catch {\n const [key, state] = await memoryAttemptFor(req);\n state.count += 1;\n if (state.count >= MAX_FAILURES) state.blockedUntil = Date.now() + WINDOW_MS;\n attempts.set(key, state);\n retryAfter = Math.max(0, Math.ceil((state.blockedUntil - Date.now()) / 1000));\n }\n await new Promise((resolve) => setTimeout(resolve, 450));\n return retryAfter;\n}\n\nexport async function clearLoginFailures(req: Request): Promise {\n const key = await clientKey(req);\n attempts.delete(key);\n try {\n await ensureRateTable();\n await sqlite.execute({ sql: `DELETE FROM ${RATE_TABLE} WHERE client_key = ?`, args: [key] });\n } catch {\n // Le fallback mémoire reste disponible si le stockage persistant est temporairement indisponible.\n }\n}\n\nexport function sameOrigin(req: Request): boolean {\n const target = new URL(req.url);\n const origin = req.headers.get(\"origin\");\n try {\n if (origin && origin !== \"null\") return new URL(origin).origin === target.origin;\n } catch {\n return false;\n }\n\n const referer = req.headers.get(\"referer\");\n if (referer) {\n try {\n const ref = new URL(referer);\n if (ref.origin === target.origin) return true;\n if (ref.hostname === \"val.town\" || ref.hostname.endsWith(\".val.town\")) return true;\n } catch {\n return false;\n }\n }\n\n const site = req.headers.get(\"sec-fetch-site\") || \"\";\n const mode = req.headers.get(\"sec-fetch-mode\") || \"\";\n return [\"same-origin\", \"same-site\", \"none\"].includes(site) && [\"navigate\", \"cors\", \"same-origin\"].includes(mode);\n}\n\nexport async function issueSession(): Promise<{ session: Session; cookie: string }> {\n const now = Date.now();\n const session: Session = {\n v: 2,\n iat: now,\n exp: now + SESSION_TTL_MS,\n nonce: crypto.randomUUID(),\n csrf: crypto.randomUUID(),\n };\n const payload = base64url(encoder.encode(JSON.stringify(session)));\n const token = `${payload}.${await signature(payload)}`;\n return {\n session,\n cookie: `${COOKIE}=${encodeURIComponent(token)}; Path=/; HttpOnly; Secure; SameSite=Strict; Max-Age=${Math.floor(SESSION_TTL_MS / 1000)}`,\n };\n}\n\nexport async function getSession(req: Request): Promise {\n if (!authConfigured()) return null;\n const token = cookies(req)[COOKIE] || \"\";\n const [payload, provided, extra] = token.split(\".\");\n if (!payload || !provided || extra || !safeEqual(provided, await signature(payload))) return null;\n try {\n const session = JSON.parse(decoder.decode(decode64url(payload))) as Session;\n const now = Date.now();\n if (session.v !== 2 || !session.csrf || !session.nonce || session.iat > now + 30_000 || session.exp <= now) return null;\n return session;\n } catch {\n return null;\n }\n}\n\nexport function validCsrf(req: Request, session: Session): boolean {\n return sameOrigin(req) && safeEqual(req.headers.get(\"x-csrf-token\") || \"\", session.csrf);\n}\n\nexport function expiredCookie(): string {\n return `${COOKIE}=; Path=/; HttpOnly; Secure; SameSite=Strict; Max-Age=0`;\n}\n",[],[448,649],"62ee387a-6c67-43fd-a8ad-3c242675cf72","api.ts","019f66f6-e505-736f-a2c2-f7c8121d5fcf",["D",1784138884418],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { openN8nCircuit, reserveN8nExecution } from \"./n8n-budget.ts\";\nimport { isQueueableBusinessAction, queueBusinessAction } from \"./business-queue.ts\";\n\nexport type ApiResult> = T & { ok?: boolean; error?: string };\n\nconst BASE = (Deno.env.get(\"PISCINE_N8N_BASE\") || \"\").replace(/\\/$/, \"\");\nconst BRIDGE_KEY = Deno.env.get(\"PISCINE_BRIDGE_KEY\") || \"\";\nconst INTERNAL_PATH = (Deno.env.get(\"PISCINE_N8N_INTERNAL_PATH\") || \"\").trim();\nconst AI_PATH = `${Deno.env.get(\"PISCINE_AI_PATH_A\") || \"\"}${Deno.env.get(\"PISCINE_AI_PATH_B\") || \"\"}`;\n\nconst ACTION_MAP: Record = {\n \"client.create\": \"create_lead\",\n \"client.context\": \"client_context\",\n \"availability.check\": \"check_availability\",\n \"rdv.create\": \"book_appointment\",\n \"devis.create\": \"create_quote\",\n \"knowledge.lookup\": \"knowledge_lookup\",\n \"next.action\": \"next_best_action\",\n \"quote.create\": \"quote_create_v2\",\n \"quote.update\": \"quote_update_v2\",\n \"quote.recalculate\": \"quote_recalculate_v2\",\n \"quote.get\": \"quote_get_v2\",\n \"quote.status\": \"quote_status_v2\",\n \"invoice.from_quote\": \"invoice_from_quote\",\n \"invoice.get\": \"invoice_get\",\n \"invoice.mark_paid\": \"invoice_mark_paid\",\n \"task.create\": \"task_create\",\n};\n\nconst ACTION_CACHE_TTL_SECONDS: Record = {\n \"quote.get\": 300,\n \"invoice.get\": 300,\n \"client.context\": 120,\n \"knowledge.lookup\": 600,\n};\n\nconst READ_CACHE_TTL_SECONDS: Record = {\n \"health\": 300,\n \"bootstrap\": 300,\n \"dashboard.snapshot\": 180,\n \"requests.list\": 90,\n \"clients.list\": 180,\n \"appointments.list\": 120,\n \"documents.list\": 180,\n};\n\nasync function ensureReadCache() {\n await sqlite.execute(`create table if not exists n8n_read_cache (\n cache_key text primary key,\n payload_json text not null,\n expires_at integer not null,\n updated_at text not null\n )`);\n}\n\nasync function readN8nCache(\n action: string,\n data: Record,\n): Promise | null> {\n await ensureReadCache();\n const cacheKey = action + \":\" + JSON.stringify(data);\n const result = await sqlite.execute({\n sql: `select payload_json from n8n_read_cache\n where cache_key=:cache_key and expires_at>unixepoch()\n limit 1`,\n args: { cache_key: cacheKey },\n });\n if (!result.rows.length) return null;\n try {\n return JSON.parse(String((result.rows[0] as Record).payload_json || \"{}\")) as ApiResult;\n } catch {\n return null;\n }\n}\n\nasync function writeN8nCache(\n action: string,\n data: Record,\n payload: ApiResult,\n ttlSeconds: number,\n) {\n await ensureReadCache();\n const cacheKey = action + \":\" + JSON.stringify(data);\n await sqlite.batch([\n {\n sql: `insert into n8n_read_cache (cache_key,payload_json,expires_at,updated_at)\n values (:cache_key,:payload_json,unixepoch()+:ttl_seconds,datetime('now'))\n on conflict(cache_key) do update set\n payload_json=excluded.payload_json,\n expires_at=excluded.expires_at,\n updated_at=excluded.updated_at`,\n args: {\n cache_key: cacheKey,\n payload_json: JSON.stringify(payload).slice(0, 100_000),\n ttl_seconds: ttlSeconds,\n },\n },\n `delete from n8n_read_cache where expires_at<=unixepoch()`,\n ]);\n}\n\nfunction errorCode(value: unknown, fallback: string): string {\n const text = String(value || fallback).slice(0, 120);\n return /^[a-z0-9_:-]+$/i.test(text) ? text : fallback;\n}\n\nasync function fetchJson(\n url: string,\n init: RequestInit,\n timeoutMs = 10_000,\n budgetPurpose = \"api\",\n): Promise> {\n const budget = await reserveN8nExecution(\n \"production\",\n `api:${budgetPurpose}:${crypto.randomUUID()}`,\n { channel: \"valtown_api\", purpose: budgetPurpose },\n );\n if (!budget.allowed) {\n throw new Error(errorCode(budget.error, \"n8n_project_daily_budget_exhausted\"));\n }\n const controller = new AbortController();\n const timer = setTimeout(() => controller.abort(), timeoutMs);\n try {\n const response = await fetch(url, { ...init, signal: controller.signal });\n const raw = (await response.text()).slice(0, 100_000);\n if (/execution limit reached|max executions|quota.*execution/i.test(raw)) {\n await openN8nCircuit(\"n8n_account_execution_limit_reached\", 86400);\n throw new Error(\"n8n_account_execution_limit_reached\");\n }\n let payload: any = {};\n try {\n payload = raw ? JSON.parse(raw) : {};\n } catch {\n throw new Error(\"invalid_upstream_json\");\n }\n if (!response.ok || payload?.ok === false) throw new Error(errorCode(payload?.error || payload?.code, `upstream_${response.status}`));\n return payload as ApiResult;\n } finally {\n clearTimeout(timer);\n }\n}\n\nexport function integrationConfig() {\n return {\n businessApi: Boolean(BASE && BRIDGE_KEY),\n actionApi: Boolean(BASE && INTERNAL_PATH && BRIDGE_KEY),\n aiApi: Boolean(BASE && BRIDGE_KEY && AI_PATH),\n securityApi: Boolean(BASE && BRIDGE_KEY),\n };\n}\n\nexport async function cockpitApi>(action: string, data: Record = {}): Promise> {\n if (!BASE || !BRIDGE_KEY) throw new Error(\"cockpit_gateway_not_configured\");\n const ttlSeconds = READ_CACHE_TTL_SECONDS[action] || 0;\n if (ttlSeconds) {\n const cached = await readN8nCache(action, data);\n if (cached) return cached;\n }\n const result = await fetchJson(`${BASE}/webhook/secretariat-pisciniste-cockpit-api-v1`, {\n method: \"POST\",\n headers: {\n \"content-type\": \"application/json\",\n \"x-piscine-key\": BRIDGE_KEY,\n \"x-piscine-source\": \"valtown-cockpit\",\n \"x-request-id\": crypto.randomUUID(),\n },\n body: JSON.stringify({ action, data }),\n }, 10_000, `cockpit:${action}`);\n if (ttlSeconds) await writeN8nCache(action, data, result, ttlSeconds);\n return result;\n}\n\nexport async function cockpitAction>(action: string, data: Record = {}): Promise> {\n if (action === \"quote.send\") return sendDocumentEmail(\"quote\", String(data.id || \"\"));\n if (action === \"invoice.send\") return sendDocumentEmail(\"invoice\", String(data.id || \"\"));\n if (!BASE || !INTERNAL_PATH || !BRIDGE_KEY) throw new Error(\"cockpit_action_gateway_not_configured\");\n const mapped = ACTION_MAP[action];\n if (!mapped) throw new Error(\"unsupported_cockpit_action\");\n\n const customerPhone = String(data.telephone ?? data.customer_phone ?? \"\").trim();\n const explicit = data.explicit_confirmation === true || data.explicit_confirmation === \"true\" || data.explicit_confirmation === \"on\";\n const businessData = {\n ...data,\n customer_name: data.nom ?? data.customer_name ?? \"\",\n customer_phone: customerPhone,\n address: data.adresse ?? data.address ?? \"\",\n city: data.ville ?? data.city ?? \"\",\n pool_type: data.type_bassin ?? data.pool_type ?? \"\",\n problem: data.objet ?? data.description ?? data.problem ?? \"\",\n intent: data.intent ?? \"autre\",\n urgency: data.urgence ?? \"normale\",\n appointment_datetime: data.date_heure ?? data.appointment_datetime ?? \"\",\n explicit_confirmation: explicit,\n };\n\n const ttlSeconds = ACTION_CACHE_TTL_SECONDS[action] || 0;\n if (ttlSeconds) {\n const cached = await readN8nCache(\"action:\" + action, data);\n if (cached) return cached;\n }\n const cockpitCallId = `cockpit-${crypto.randomUUID()}`;\n try {\n const result = await fetchJson(`${BASE}/webhook/${INTERNAL_PATH}`, {\n method: \"POST\",\n headers: {\n \"content-type\": \"application/json\",\n \"x-piscine-key\": BRIDGE_KEY,\n \"x-piscine-source\": \"valtown-cockpit\",\n \"x-request-id\": crypto.randomUUID(),\n },\n body: JSON.stringify({\n args: { action: mapped, data: businessData },\n call: { call_id: cockpitCallId, from_number: customerPhone },\n }),\n }, 12_000, `cockpit_action:${action}`);\n if (ttlSeconds) await writeN8nCache(\"action:\" + action, data, result, ttlSeconds);\n return result;\n } catch (error) {\n const reason = error instanceof Error ? error.message : \"upstream_unavailable\";\n if (isQueueableBusinessAction(mapped) && /n8n_|upstream_|invalid_upstream_json/.test(reason)) {\n return await queueBusinessAction(mapped, businessData, cockpitCallId, reason) as ApiResult;\n }\n throw error;\n }\n}\n\nexport async function aiSupervision>(): Promise> {\n if (!BASE || !BRIDGE_KEY || !AI_PATH) throw new Error(\"ai_supervision_gateway_not_configured\");\n const cached = await readN8nCache(\"ai.supervision\", {});\n if (cached) return cached;\n const result = await fetchJson(`${BASE}/webhook/${AI_PATH}`, {\n method: \"POST\",\n headers: {\n \"content-type\": \"application/json\",\n \"x-piscine-key\": BRIDGE_KEY,\n \"x-piscine-source\": \"valtown-cockpit\",\n \"x-request-id\": crypto.randomUUID(),\n },\n body: JSON.stringify({ action: \"supervision.snapshot\" }),\n }, 10_000, \"ai.supervision\");\n await writeN8nCache(\"ai.supervision\", {}, result, 300);\n return result;\n}\n\nexport async function securityAudit>(): Promise> {\n if (!BASE || !BRIDGE_KEY) throw new Error(\"security_audit_gateway_not_configured\");\n const cached = await readN8nCache(\"security.audit\", {});\n if (cached) return cached;\n const result = await fetchJson(`${BASE}/webhook/secretariat-pisciniste-security-audit-v1`, {\n method: \"POST\",\n headers: {\n \"content-type\": \"application/json\",\n \"x-piscine-key\": BRIDGE_KEY,\n \"x-piscine-source\": \"valtown-cockpit\",\n \"x-request-id\": crypto.randomUUID(),\n },\n body: \"{}\",\n }, 10_000, \"security.audit\");\n await writeN8nCache(\"security.audit\", {}, result, 600);\n return result;\n}\n\nexport async function sendDocumentEmail>(kind: \"quote\" | \"invoice\", documentId: string): Promise> {\n if (!BASE || !BRIDGE_KEY) throw new Error(\"document_delivery_not_configured\");\n if (!/^[0-9a-f-]{36}$/i.test(documentId)) throw new Error(\"invalid_document_id\");\n return fetchJson(`${BASE}/webhook/sp-document-delivery-v1`, {\n method: \"POST\",\n headers: {\n \"content-type\": \"application/json\",\n \"x-piscine-key\": BRIDGE_KEY,\n \"x-piscine-source\": \"valtown-cockpit\",\n \"x-request-id\": crypto.randomUUID(),\n },\n body: JSON.stringify(kind === \"invoice\"\n ? { document_type: \"invoice\", invoice_id: documentId }\n : { document_type: \"quote\", devis_id: documentId }),\n }, 18_000);\n}\n",[],[448,656],["D",1784138884418],[472,473,474,475,476,477,478,479,480,481,482,483,484,485,486,487,488,489,490,491],[448],"68d36129-922f-45d5-8240-9d3c6529d716","n8n-execution-policy.md","019f66f6-e505-736f-a2c2-ed81a79ab645",["D",1784138884418],"# Politique de budget d’exécutions n8n — Pisciniste\n\nVersion : 2026-07-12-strict-v1 \nFuseau de comptage : Europe/Paris\n\n## Limites non négociables\n\n- 10 exécutions n8n de test ou de vérification maximum par jour pour le projet Pisciniste.\n- Les catégories `test` et `verification` partagent le même plafond de 10.\n- Plafond de sécurité du projet : 83 exécutions n8n par jour, avec alerte à partir de 60.\n- Budget du compte : 2 500 exécutions par mois ; la moyenne cible est 83 par jour.\n- Les micro-tests successifs sont interdits.\n- Un test d’exécution n8n n’est autorisé qu’après un bloc fonctionnel majeur et complet.\n- La stratégie par défaut est `static_first` : validation du code, du contrat, du SQL et des permissions avant tout test d’exécution.\n\n## Ce qui consomme une exécution\n\nUn webhook de production, un déclencheur planifié, une exécution manuelle ou un outil de test n8n consomme une exécution. La lecture de la définition d’un workflow, sa mise à jour et sa publication ne déclenchent pas le workflow.\n\n## Réductions obligatoires\n\n- Les lectures répétitives du cockpit sont mises en cache de 90 à 300 secondes.\n- Chaque appel Val Town vers n8n doit réserver une unité dans le registre local avant l’appel.\n- Les événements vocaux intermédiaires sont stockés dans Val Town ; seul `call.ended` est transmis à n8n.\n- Les statuts Twilio sont stockés immédiatement dans une file durable, puis envoyés par lots de 1 à 50, au maximum une fois toutes les 4 heures et seulement si la file n’est pas vide.\n- Aucun callback Twilio ne doit provoquer un transfert immédiat individuel vers n8n.\n- Le déclencheur de relance du workflow principal reste désactivé. S’il est réactivé, sa cadence maximale est une fois toutes les 6 heures.\n\n## Procédure de modification\n\n1. Regrouper les changements en un bloc fonctionnel complet.\n2. Faire les contrôles statiques et SQL sans déclencher n8n.\n3. Vérifier le budget du jour.\n4. Si une exécution est réellement nécessaire, réserver une unité de test avec un motif explicite.\n5. Effectuer un seul scénario de bout en bout couvrant le bloc.\n6. Corriger hors ligne avant toute nouvelle exécution.\n\n## Verrou du 12 juillet 2026\n\nLe budget de test est volontairement marqué à 10/10 : aucun autre test n8n n’est autorisé aujourd’hui.\n\n## Incident observé\n\nLe principal épuisement du quota du 12 juillet 2026 venait du workflow ViralOS « Reference Intelligence Hub v1.1 », avec environ 2 448 exécutions en erreur. Il est inactif. Cet incident est distinct du projet Pisciniste, mais confirme qu’aucun workflow planifié ne doit être activé sans contrôle préalable de sa fréquence et de ses chemins de boucle.\n",[],[453,666],["D",1784138884418],[470],[453],["D",1783720739803],["D",1789526460011],{"_16":17,"_89":85},{"_16":17,"_82":83,"_84":85,"_33":34,"_86":87,"_88":26},{"_68":69,"_20":70,"_18":71,"_72":19,"_73":74,"_75":76,"_77":28,"_78":19,"_79":44,"_80":21,"_81":17},"ctx",{"_61":-5,"_111":713,"_714":715,"_716":717,"_718":26,"_719":26,"_720":26,"_721":38,"_722":-5,"_723":-7,"_724":-7,"_725":42,"_726":26,"_727":26,"_728":-5,"_729":26,"_730":26,"_731":26,"_732":-5},"ENV",{"_684":685,"_686":687,"_688":392,"_689":690,"_691":692,"_693":694,"_695":696,"_697":698,"_699":700,"_701":702,"_703":704,"_705":706,"_707":708,"_709":710,"_711":712},"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"]

Lignes du devis

'+esc(quote.numero||'Devis')+' · '+money(quote.total_ttc)+'

Connexion

À traiter maintenant

Priorités

Actions rapides

Prochains rendez-vous

Demandes

Agenda

Clients

Documents

Pilotage

Centre d’actions

Accès directs

Assistante personnelle

Connexion e-mail sans mot de passe

Centre d’activation

Prochaines actions

Parler à la secrétaire IA

Commandes rapides

Garde-fous avant activation

Validations en attente

Automatisations candidates

Politique de communication

Connexion calendrier

Suivi de livraison Twilio

Derniers SMS suivis

Alertes de livraison

Premier SMS technique

Réglages

À compléter

Une action utile par document

'+(m.correct+m.sendQ+m.invoiceQ+m.sendI+m.collect)+' dossiers à faire avancer

Aucun document dans cette étape

'+esc(quote.numero||'Devis')+' · '+money(quote.total_ttc)+'

Facture '+(invoice.statut==='envoyee'?'créée et envoyée':'créée')+'

Cycle devis → encaissement

'+((incomplete+toSend+toInvoice)||0)+' décisions utiles

Aucun document

'+(id?esc(d.numero||'Devis'):'Nouveau devis')+'

Prestations et matériel

'+money(m.pipeline)+' en mouvement

Aucun document ici

'+esc(quote.numero||'Devis')+' · '+money(quote.total_ttc)+'

Facture enregistrée et relue

'+esc(invoice.numero||'Facture')+' · '+money(invoice.total_ttc)+'

Paiement confirmé

'+esc(invoice.numero||'Facture')+' · '+money(invoice.total_ttc)+'

Historique récent

'+esc(req.description||req.objet||'Non renseigné')+'

'+esc(rdv.type_rdv||rdv.objet||'Intervention')+'