[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8},"actionData","errors","root",{"_110":111,"_112":113},"routes/embed.x.$handle.$name.$",{"_9":10,"_11":12,"_13":14,"_15":16,"_17":18,"_19":20,"_21":-5},"handle","IDLEYER","name","secretariat-pisciniste","path","lib/platform-api-v31.ts","project",{"_22":48,"_11":12,"_35":49,"_50":-5,"_51":44,"_52":53,"_54":53,"_55":56,"_57":-5,"_58":59,"_60":61,"_62":34,"_63":-5,"_64":-5,"_65":66,"_67":68,"_69":70,"_71":72,"_73":74,"_75":-5,"_76":77,"_78":77,"_79":80,"_81":80,"_82":80,"_83":77,"_84":77,"_85":86,"_87":88,"_89":90,"_91":44},"file",{"_22":23,"_11":24,"_25":26,"_27":28,"_29":30,"_31":32,"_33":34,"_35":36,"_37":38,"_39":40,"_41":42,"_43":44,"_45":-5,"_13":46},"permalink","https://www.val.town/x/IDLEYER/secretariat-pisciniste/code/lib/platform-api-v31.ts","extension","id","aec50b97-3b89-4833-bc19-69c017fbbd44","platform-api-v31.ts","fileId","019fe958-cab0-77ed-bedf-a31dd0ef71cd","parentId","fedf50c4-7cab-11f1-99bd-1607ee4eb77e","branchId","002594a0-197f-4348-8ce0-a1205dd09edd","branchVersion",294,"latest",true,"createdAt",["D",1786762607367],"version",8,"fileType","script","content","import { COMMAND_SURFACE_PROJECTION } from \"./owner-action-contract-v85.ts\";\n\nexport const PLATFORM_API_RELEASE = \"89.8-demo-tenant-readiness\";\nexport const PLATFORM_COMMAND_RELEASE = \"88.0-command-surface-sql\";\n\nconst BASE = (Deno.env.get(\"PLATFORM_SUPABASE_URL\") || \"\").replace(/\\/$/, \"\");\nconst KEY = Deno.env.get(\"PLATFORM_SUPABASE_PUBLISHABLE_KEY\") || \"\";\nconst SECRET = Deno.env.get(\"PLATFORM_AUTH_GATEWAY_SECRET\") || \"\";\nconst EDGE_ENDPOINT = `${BASE}/functions/v1/platform-cockpit-gateway`;\n\ntype Json = Record;\n\nfunction object(value: unknown): Json {\n return value && typeof value === \"object\" && !Array.isArray(value) ? value as Json : {};\n}\n\nfunction rows(value: unknown): Json[] {\n return Array.isArray(value) ? value.filter((item) => item && typeof item === \"object\" && !Array.isArray(item)).map(object) : [];\n}\n\nfunction text(value: unknown, max = 200): string {\n return String(value ?? \"\").trim().slice(0, max);\n}\n\nfunction number(value: unknown, fallback = 0): number {\n const result = Number(value);\n return Number.isFinite(result) ? result : fallback;\n}\n\nfunction tenant(ctx: Json): string {\n const value = text(ctx.tenant_id, 80).toLowerCase();\n if (!/^[a-z0-9][a-z0-9_-]{2,79}$/.test(value)) throw new Error(\"tenant_context_required\");\n return value;\n}\n\nfunction statusOf(result: Json, fallback = 500): number {\n return Math.max(200, Math.min(599, number(result.http_status, result.ok === false ? fallback : 200)));\n}\n\nasync function parse(response: Response): Promise {\n const raw = (await response.text()).slice(0, 500_000);\n try {\n return object(raw ? JSON.parse(raw) : {});\n } catch {\n throw new Error(\"invalid_platform_response\");\n }\n}\n\nexport function platformConfigured() {\n return {\n platformApi: Boolean(BASE && KEY && SECRET.length >= 40),\n sourceOfTruth: \"supabase\",\n };\n}\n\nasync function edgeRequest(operation: string, payload: Json): Promise {\n if (!platformConfigured().platformApi) throw new Error(\"platform_cockpit_not_configured\");\n const controller = new AbortController();\n const timer = setTimeout(() => controller.abort(), 10_000);\n try {\n const response = await fetch(EDGE_ENDPOINT, {\n method: \"POST\",\n headers: {\n \"content-type\": \"application/json\",\n accept: \"application/json\",\n apikey: KEY,\n \"x-platform-auth-secret\": SECRET,\n },\n body: JSON.stringify({ operation, payload }),\n signal: controller.signal,\n });\n const result = await parse(response);\n if (!response.ok || result.ok === false) {\n const error = text(result.error || result.error_code, 120) || `platform_http_${response.status}`;\n const failure = new Error(error) as Error & { status?: number; result?: Json };\n failure.status = statusOf(result, response.status);\n failure.result = result;\n throw failure;\n }\n return result;\n } finally {\n clearTimeout(timer);\n }\n}\n\n/**\n * Lecture ciblée via platform_business_query_v32.\n * Complète le bootstrap : celui-ci rapatrie tout le tenant, ce qui est correct\n * pour amorcer le cockpit mais coûteux pour lire une seule ligne ou une liste.\n * Toutes les opérations sont filtrées par tenant_id côté SQL.\n */\nasync function businessQuery(\n ctx: Json,\n operation: string,\n payload: Json = {},\n idempotencyKey?: string,\n): Promise {\n return edgeRequest(\"business.query\", {\n tenant_id: tenant(ctx),\n query_operation: operation,\n query_payload: payload,\n idempotency_key: idempotencyKey ?? null,\n });\n}\n\nfunction missionRow(value: unknown): Json {\n const row = object(value);\n return {\n ...row,\n action: row.action ?? row.action_key ?? \"\",\n risk: row.risk ?? row.risk_level ?? \"low\",\n };\n}\n\nfunction capabilityRow(value: unknown): Json {\n const row = object(value);\n return {\n ...row,\n capability_key: row.capability_key ?? row.code ?? \"\",\n mode: row.mode ?? row.operation_mode ?? \"read\",\n last_health: row.last_health ?? row.health_status ?? \"unknown\",\n };\n}\n\nexport async function platformBootstrap(ctx: Json): Promise {\n return edgeRequest(\"bootstrap\", { tenant_id: tenant(ctx) });\n}\n\nexport async function listPlatformCapabilities(ctx: Json): Promise {\n const result = await edgeRequest(\"autonomy.capabilities\", { tenant_id: tenant(ctx) });\n return { ...result, capabilities: rows(result.capabilities).map(capabilityRow) };\n}\n\nexport async function listPlatformMissions(ctx: Json, options: Json = {}): Promise {\n const result = await edgeRequest(\"autonomy.missions\", {\n tenant_id: tenant(ctx),\n status: text(options.status, 40),\n limit: Math.max(1, Math.min(100, number(options.limit, 30))),\n offset: Math.max(0, Math.min(100_000, number(options.offset, 0))),\n });\n return { ...result, missions: rows(result.missions).map(missionRow) };\n}\n\nexport async function listPlatformCommitments(ctx: Json, options: Json = {}): Promise {\n return edgeRequest(\"autonomy.commitments\", {\n tenant_id: tenant(ctx),\n status: text(options.status, 40) || \"all\",\n limit: Math.max(1, Math.min(100, number(options.limit, 50))),\n });\n}\n\nexport async function getPlatformMission(ctx: Json, missionId: unknown): Promise {\n const id = text(missionId, 80).toLowerCase();\n if (!/^[0-9a-f]{8}-[0-9a-f]{4}-[1-5][0-9a-f]{3}-[89ab][0-9a-f]{3}-[0-9a-f]{12}$/.test(id)) {\n throw new Error(\"invalid_mission_id\");\n }\n const result = await edgeRequest(\"autonomy.mission\", { tenant_id: tenant(ctx), mission_id: id });\n return { ...result, mission: missionRow(result.mission) };\n}\n\nexport async function platformBusinessBootstrap(ctx: Json): Promise {\n return edgeRequest(\"business.bootstrap\", { tenant_id: tenant(ctx) });\n}\n\nexport async function platformPilotStatus(ctx: Json): Promise {\n return edgeRequest(\"pilot.status\", { tenant_id: tenant(ctx) });\n}\n\nexport async function platformSupervision(ctx: Json): Promise {\n return edgeRequest(\"pilot.supervision\", { tenant_id: tenant(ctx) });\n}\n\nexport async function platformPilotConfigure(\n ctx: Json,\n configValue: unknown,\n expectedVersion: unknown,\n): Promise {\n const role = text(ctx.role, 40).toLowerCase();\n if (![\"owner\", \"admin\"].includes(role)) throw new Error(\"owner_role_required\");\n const expected = number(expectedVersion, -1);\n if (!Number.isInteger(expected) || expected < 0) throw new Error(\"configuration_version_required\");\n return edgeRequest(\"pilot.configure\", {\n tenant_id: tenant(ctx),\n config: object(configValue),\n expected_version: expected,\n actor: {\n staff_id: text(ctx.staff_id || ctx.actor_id, 80),\n role,\n correlation_id: text(ctx.correlation_id, 200),\n },\n });\n}\n\nexport async function platformPrepareTestSms(ctx: Json, recipient: unknown): Promise {\n const role = text(ctx.role, 40).toLowerCase();\n if (role !== \"owner\") throw new Error(\"owner_resolution_required\");\n return edgeRequest(\"pilot.sms.prepare\", {\n tenant_id: tenant(ctx),\n recipient: text(recipient, 40),\n actor: {\n staff_id: text(ctx.staff_id || ctx.actor_id, 80),\n role,\n correlation_id: text(ctx.correlation_id, 200),\n },\n });\n}\n\nexport async function platformSendTestSms(ctx: Json, requestIdValue: unknown): Promise {\n const role = text(ctx.role, 40).toLowerCase();\n if (role !== \"owner\") throw new Error(\"owner_resolution_required\");\n const accountSid = Deno.env.get(\"PISCINE_TWILIO_ACCOUNT_SID\") || \"\";\n const authToken = Deno.env.get(\"PISCINE_TWILIO_AUTH_TOKEN\") || \"\";\n if (!accountSid.startsWith(\"AC\") || authToken.length < 20) throw new Error(\"twilio_not_configured\");\n const requestId = text(requestIdValue, 200);\n if (requestId.length < 12) throw new Error(\"test_sms_request_required\");\n const authorization = await edgeRequest(\"pilot.sms.authorize\", {\n tenant_id: tenant(ctx),\n request_id: requestId,\n actor: {\n staff_id: text(ctx.staff_id || ctx.actor_id, 80),\n role,\n correlation_id: text(ctx.correlation_id, 200),\n },\n });\n const dispatch = object(authorization.dispatch);\n const toNumber = text(dispatch.to_number, 40);\n const fromNumber = text(dispatch.from_number, 40);\n const body = text(dispatch.body, 500);\n const outboxId = text(authorization.outbox_id, 80);\n if (!/^\\+[1-9][0-9]{7,14}$/.test(toNumber) || !/^\\+[1-9][0-9]{7,14}$/.test(fromNumber) || body.length < 10 || outboxId.length !== 36) {\n throw new Error(\"test_sms_dispatch_contract_invalid\");\n }\n let sid = \"\";\n let providerStatus = \"failed\";\n let errorCode = \"\";\n let providerHttpStatus = 0;\n try {\n const response = await fetch(`https://api.twilio.com/2010-04-01/Accounts/${encodeURIComponent(accountSid)}/Messages.json`, {\n method: \"POST\",\n headers: {\n authorization: \"Basic \" + btoa(accountSid + \":\" + authToken),\n \"content-type\": \"application/x-www-form-urlencoded\",\n accept: \"application/json\",\n },\n body: new URLSearchParams({ To: toNumber, From: fromNumber, Body: body }),\n signal: AbortSignal.timeout(15_000),\n });\n providerHttpStatus = response.status;\n const payload = object(JSON.parse((await response.text()).slice(0, 100_000) || \"{}\"));\n sid = text(payload.sid, 40);\n providerStatus = text(payload.status, 40).toLowerCase() || (response.ok ? \"queued\" : \"failed\");\n if (!response.ok || !/^(SM|MM)[0-9A-Za-z]{32}$/.test(sid)) {\n sid = \"\";\n errorCode = text(payload.code || payload.message, 120) || `twilio_http_${response.status}`;\n }\n } catch (error) {\n errorCode = error instanceof Error ? text(error.message, 120) : \"twilio_test_sms_unreachable\";\n }\n let finalized: Json;\n try {\n finalized = await edgeRequest(\"pilot.sms.finalize\", {\n tenant_id: tenant(ctx),\n outbox_id: outboxId,\n message_sid: sid,\n provider_status: providerStatus,\n error_code: errorCode || null,\n });\n } catch (error) {\n return {\n ok: false,\n sms_sent: Boolean(sid),\n delivery_uncertain: Boolean(sid),\n error: \"test_sms_finalization_unavailable\",\n provider_http_status: providerHttpStatus,\n automatic_retry: false,\n global_outbound_unchanged: true,\n safe_to_retry: false,\n };\n }\n return {\n ok: finalized.sms_sent === true,\n sms_sent: finalized.sms_sent === true,\n recipient_suffix: text(authorization.recipient_suffix, 4),\n provider_status: text(finalized.provider_status || providerStatus, 40),\n provider_message_suffix: sid ? sid.slice(-8) : null,\n provider_http_status: providerHttpStatus,\n error_code: text(finalized.error_code || errorCode, 120) || null,\n automatic_retry: false,\n global_outbound_unchanged: true,\n recipient_scrubbed: finalized.recipient_scrubbed === true,\n source_of_truth: \"supabase\",\n n8n_execution_used: false,\n };\n}\n\nexport async function platformProductAxes(ctx: Json): Promise {\n return edgeRequest(\"product.axes\", { tenant_id: tenant(ctx) });\n}\n\nfunction includesSearch(row: Json, search: string): boolean {\n if (!search) return true;\n return JSON.stringify(row).toLowerCase().includes(search);\n}\n\nfunction hasStatus(row: Json, status: string): boolean {\n if (!status || status === \"all\") return true;\n if (status === \"urgent\") return [\"haute\", \"urgente\"].includes(text(row.urgence, 40).toLowerCase());\n return [row.statut, row.status, row.ocr_statut].some((value) => text(value, 40).toLowerCase() === status);\n}\n\nfunction page(input: Json[], options: Json): Json[] {\n const search = text(options.search, 120).toLowerCase();\n const status = text(options.status, 40).toLowerCase();\n const offset = Math.max(0, Math.min(100_000, number(options.offset, 0)));\n const limit = Math.max(1, Math.min(100, number(options.limit, 50)));\n return input.filter((row) => includesSearch(row, search) && hasStatus(row, status)).slice(offset, offset + limit);\n}\n\nexport async function platformBusinessData(ctx: Json, resource: string, options: Json = {}): Promise {\n const data = await platformBusinessBootstrap(ctx);\n if (resource === \"snapshot\") return data;\n if (resource === \"requests\") {\n const result = page(rows(data.demandes), options);\n return { ok: true, demandes: result, requests: result, source_of_truth: \"supabase\" };\n }\n if (resource === \"clients\") {\n const result = page(rows(data.clients), options);\n return { ok: true, clients: result, source_of_truth: \"supabase\" };\n }\n if (resource === \"appointments\") {\n let result = page(rows(data.rendez_vous), options);\n const from = text(options.from, 40);\n const to = text(options.to, 40);\n if (from) result = result.filter((row) => text(row.date_heure, 50) >= from);\n if (to) result = result.filter((row) => text(row.date_heure, 50) <= to);\n return { ok: true, rendez_vous: result, appointments: result, source_of_truth: \"supabase\" };\n }\n if (resource === \"documents\") {\n const kind = text(options.kind, 20) || \"quotes\";\n const source = kind === \"invoices\" ? rows(data.factures) : kind === \"purchases\" ? rows(data.achats) : rows(data.devis);\n const result = page(source, options);\n return {\n ok: true,\n kind,\n documents: result,\n ...(kind === \"invoices\" ? { factures: result } : kind === \"purchases\" ? { achats: result } : { devis: result }),\n source_of_truth: \"supabase\",\n };\n }\n if (resource === \"universal-summary\") {\n const result = await businessQuery(ctx, \"universal.summary\");\n return {\n ...result,\n source_of_truth: \"supabase\",\n data_scope: \"production\",\n };\n }\n if (resource === \"cases\" || resource === \"service-cases\") {\n const status = text(options.status, 40).toLowerCase();\n const result = await businessQuery(ctx, \"service_case.list\", {\n limit: 100,\n status: status && status !== \"all\" ? status : null,\n });\n const allCases = rows(result.items)\n .filter((row) => includesSearch(row, text(options.search, 120).toLowerCase()));\n const offset = Math.max(0, Math.min(100_000, number(options.offset, 0)));\n const limit = Math.max(1, Math.min(100, number(options.limit, 50)));\n const cases = allCases.slice(offset, offset + limit);\n return {\n ok: true,\n cases,\n service_cases: cases,\n count: cases.length,\n total: allCases.length,\n truth_model_release: number(result.truth_model_release, 89),\n data_scope: \"production\",\n source_of_truth: \"supabase\",\n };\n }\n if (resource === \"sites\" || resource === \"assets\") {\n const operation = resource === \"sites\" ? \"site.list\" : \"asset.list\";\n const result = await businessQuery(ctx, operation, { limit: 100 });\n const allItems = rows(result.items)\n .filter((row) => includesSearch(row, text(options.search, 120).toLowerCase()));\n const items = page(allItems, options);\n return {\n ok: true,\n items,\n [resource]: items,\n count: items.length,\n total: allItems.length,\n truth_model_release: number(result.truth_model_release, 89),\n data_scope: \"production\",\n source_of_truth: \"supabase\",\n };\n }\n if (resource === \"tasks\") {\n // Les tâches n'étaient exposées par aucune ressource : elles existaient en\n // base sans jamais être consultables depuis le cockpit.\n const status = text(options.status, 40).toLowerCase();\n const result = await businessQuery(ctx, \"task.list\", {\n statut: status && status !== \"all\" ? status : null,\n });\n const ordre: Record = { urgente: 0, haute: 1, normale: 2, basse: 3 };\n const taches = rows(result.tasks)\n .filter((row) => includesSearch(row, text(options.search, 120).toLowerCase()))\n .sort((a, b) => {\n const pa = ordre[text(a.priorite, 20).toLowerCase()] ?? 9;\n const pb = ordre[text(b.priorite, 20).toLowerCase()] ?? 9;\n if (pa !== pb) return pa - pb;\n return text(b.created_at, 40).localeCompare(text(a.created_at, 40));\n });\n const fenetre = taches.slice(\n Math.max(0, number(options.offset, 0)),\n Math.max(0, number(options.offset, 0)) + Math.max(1, Math.min(100, number(options.limit, 50))),\n );\n return {\n ok: true,\n taches: fenetre,\n tasks: fenetre,\n total: taches.length,\n a_faire: taches.filter((row) => text(row.statut, 20) === \"a_faire\").length,\n en_retard: taches.filter((row) => {\n const echeance = text(row.due_at, 40);\n return echeance !== \"\" && echeance < new Date().toISOString() && text(row.statut, 20) === \"a_faire\";\n }).length,\n source_of_truth: \"supabase\",\n };\n }\n throw new Error(\"unsupported_data_resource\");\n}\n\nexport async function platformBusinessDocument(ctx: Json, kind: \"quote\" | \"invoice\", idValue: unknown): Promise {\n const id = text(idValue, 80).toLowerCase();\n if (!/^[0-9a-f-]{36}$/.test(id)) throw new Error(\"invalid_document_id\");\n const result = kind === \"invoice\"\n ? await businessQuery(ctx, \"invoice.get\", { invoice_id: id })\n : await businessQuery(ctx, \"quote.get\", { quote_id: id });\n return {\n ok: true,\n ...(kind === \"invoice\"\n ? { facture: object(result.invoice), devis: object(result.devis) }\n : { devis: object(result.quote) }),\n client: object(result.client),\n settings: object(result.settings),\n lignes: rows(result.lignes),\n lignes_count: number(result.lignes_count, rows(result.lignes).length),\n truth_model_release: number(result.truth_model_release, 88),\n source_of_truth: \"supabase\",\n };\n}\n\nexport async function platformBusinessOperations(ctx: Json): Promise {\n const data = await platformBusinessBootstrap(ctx);\n const providers = object(data.integrations);\n const axesSnapshot = object(data.operational_axes);\n const summary = object(axesSnapshot.summary);\n const axes = rows(axesSnapshot.axes);\n const total = number(summary.total, axes.length);\n const operational = number(summary.operational, 0);\n const partial = number(summary.partial, 0);\n const blocked = number(summary.blocked, 0);\n const readyUnproven = number(summary.ready_unproven, 0);\n const blockers = axes\n .filter((axis) => axis.status === \"blocked\")\n .flatMap((axis) => Array.isArray(axis.blockers) ? axis.blockers : [])\n .map((value) => text(value, 160));\n return {\n ok: data.ok !== false && axesSnapshot.ok !== false,\n mode: blocked > 0 ? \"limited\" : \"available\",\n label: total > 0 ? `${operational}/${total} axes opérationnels` : \"État indisponible\",\n explanation: blocked > 0\n ? `${blocked} axe(s) bloqué(s), ${partial} partiel(s), ${readyUnproven} prêt(s) à éprouver.`\n : \"Aucun axe structurant n’est bloqué.\",\n pending_actions: blocked + partial + readyUnproven,\n blockers,\n source_of_truth: \"supabase\",\n data_scope: data.data_scope,\n axes: axesSnapshot,\n providers,\n };\n}\n\nexport async function platformBusinessHealth(ctx: Json): Promise {\n const data = await platformBusinessBootstrap(ctx);\n return {\n ok: data.ok !== false && data.source_of_truth === \"supabase\",\n service: \"secretariat-ia-platform\",\n source_of_truth: data.source_of_truth,\n checked_at: new Date().toISOString(),\n runtime: data.runtime,\n ai: data.ai,\n security: data.security,\n integrations: data.integrations,\n operational_axes: data.operational_axes,\n data_scope: data.data_scope,\n demo_data: data.demo_data,\n };\n}\n\n/**\n * Correspondance des trois nommages de la plateforme.\n *\n * Cette table traduit le nom d'action historique de l'interface\n * (client.create, devis.create, quote.send…) vers le code de capacité que la\n * passerelle Postgres comprend (request.create, quote.draft…). Elle était une\n * fermeture privée : ni la base, ni l'interface, ni un audit ne pouvaient la\n * lire. C'est précisément cette opacité qui rend le système illisible — trois\n * vocabulaires pour les mêmes actions, sans dictionnaire consultable — et qui\n * m'a fait conclure deux fois de travers lors de l'audit du 30/07.\n *\n * L'exporter ne change aucun comportement : c'est la même référence, lisible.\n */\nexport const COMMAND_MAP: Readonly> = Object.freeze(\n Object.fromEntries(\n COMMAND_SURFACE_PROJECTION.map(([command, target]) => [command, target]),\n ),\n);\n\n/**\n * Vocabulaire réellement traduisible par la passerelle.\n *\n * Exposé pour qu'un appelant puisse vérifier AVANT d'exposer un bouton qu'une\n * action se résoudra en commande. Sans ce contrôle, une action absente de la\n * carte franchit le portail d'autorisation puis échoue en 409\n * command_not_supported — un bouton visible, autorisé, et mort.\n */\nexport const COMMANDES_CONNUES: readonly string[] = Object.freeze(Object.keys(COMMAND_MAP));\n\n/** Une action se résout-elle en commande ? */\nexport function commandeConnue(action: unknown): boolean {\n return Object.prototype.hasOwnProperty.call(COMMAND_MAP, text(action, 100).toLowerCase());\n}\n\nexport function commandPayload(legacy: string, command: string, data: Json, ctx: Json): Json {\n if (legacy === \"client.create\" || command === \"request.create\") {\n const vertical = text(ctx.vertical_key, 80).toLowerCase();\n const site = {\n ...object(data.business_site),\n ...object(data.site),\n };\n const asset = {\n ...object(data.business_asset),\n ...object(data.asset),\n };\n const assetType = data.asset_type ?? data.asset_kind ?? data.type_bassin ?? data.pool_type;\n if (assetType != null && !asset.kind) asset.kind = assetType;\n const universal: Json = {\n phone: data.telephone ?? data.customer_phone ?? data.phone ?? \"\",\n name: data.nom ?? data.customer_name ?? data.name ?? \"\",\n email: data.email ?? data.customer_email ?? \"\",\n intent: data.intent ?? \"other\",\n urgency: data.urgence ?? data.urgency ?? \"normal\",\n description: data.description ?? data.request_summary ?? data.objet ?? data.problem ?? \"\",\n call_id: data.call_id ?? \"\",\n channel: data.channel ?? \"cockpit\",\n test_mode: data.test_mode === true || data.synthetic === true,\n };\n if (Object.keys(site).length) universal.site = site;\n if (Object.keys(asset).length) universal.asset = asset;\n if (vertical === \"pool_service\") {\n const pool = {\n ...object(data.business_fields),\n ...object(data.pool),\n };\n if (assetType != null && !pool.type_bassin) pool.type_bassin = assetType;\n const poolId = data.pool_id ?? pool.pool_id;\n if (poolId != null) pool.pool_id = poolId;\n universal.pool = pool;\n }\n return universal;\n }\n if (legacy === \"client.context\") return { phone: data.telephone ?? data.customer_phone ?? data.phone ?? \"\" };\n if (legacy === \"availability.check\") {\n return {\n start_date: data.start_date ?? data.date ?? \"\",\n days: number(data.days, 14),\n duration_min: number(data.duration_min, 60),\n step_min: number(data.step_min, 30),\n address: data.adresse ?? data.address ?? \"\",\n };\n }\n if (legacy === \"rdv.create\") {\n return {\n client_id: data.client_id ?? \"\",\n request_id: data.request_id ?? data.demande_id ?? \"\",\n start: data.start ?? data.date_heure ?? data.appointment_datetime ?? \"\",\n duration_min: number(data.duration_min, 60),\n type: data.type ?? data.type_rdv ?? \"intervention\",\n address: data.adresse ?? data.address ?? \"\",\n notes: data.notes ?? \"\",\n };\n }\n if (legacy === \"devis.create\" || legacy === \"quote.create\") {\n return {\n client_id: data.client_id ?? \"\",\n request_id: data.request_id ?? data.demande_id ?? \"\",\n lines: Array.isArray(data.lines) ? data.lines : Array.isArray(data.lignes) ? data.lignes : [],\n object: data.object ?? data.objet ?? \"\",\n notes: data.notes ?? \"\",\n };\n }\n if (legacy === \"quote.send\") {\n return {\n quote_id: data.quote_id ?? data.id ?? data.devis_id ?? \"\",\n approved_by: ctx.staff_id ?? ctx.actor_id ?? \"owner\",\n send_after_approval: true,\n };\n }\n if (legacy === \"task.create\") {\n return {\n title: data.title ?? data.titre ?? \"Suivi requis\",\n description: data.description ?? \"\",\n priority: data.priority ?? data.priorite ?? \"normale\",\n request_id: data.request_id ?? data.demande_id ?? \"\",\n client_id: data.client_id ?? \"\",\n due_at: data.due_at ?? \"\",\n };\n }\n if (command === \"commitment.create\") {\n return {\n service_case_id: data.service_case_id ?? data.case_id ?? \"\",\n promise: data.promise ?? data.description ?? \"\",\n due_at: data.due_at ?? \"\",\n proof_required: data.proof_required ?? \"\",\n actor_id: data.actor_id ?? ctx.staff_id ?? ctx.actor_id ?? \"assistant\",\n };\n }\n if (command === \"quote.approve\" && !data.approved_by) {\n return { ...data, approved_by: ctx.staff_id ?? ctx.actor_id ?? \"owner\" };\n }\n return data;\n}\n\nexport function normalizePlatformCommandResult(result: Json): Json {\n const accepted = result.success === true || result.ok === true;\n const actionCompleted = typeof result.action_completed === \"boolean\"\n ? result.action_completed\n : accepted;\n const needsInput = result.requires_input === true\n || result.status === \"requires_input\";\n return {\n ...result,\n ok: accepted,\n action_completed: actionCompleted,\n execution_state: text(\n result.execution_state,\n 60,\n ) || (actionCompleted ? \"completed\" : needsInput ? \"requires_input\" : accepted ? \"pending\" : \"failed\"),\n safe_to_announce: accepted,\n source_of_truth: \"supabase\",\n n8n_execution_used: false,\n };\n}\n\nexport async function platformExecuteCommand(ctx: Json, legacyAction: unknown, dataValue: unknown): Promise {\n const legacy = text(legacyAction, 100).toLowerCase();\n if (!/^[a-z][a-z0-9_.-]{1,99}$/.test(legacy)) {\n return {\n ok: false,\n success: false,\n action_completed: false,\n execution_state: \"denied\",\n safe_to_announce: false,\n error: \"invalid_command\",\n http_status: 400,\n };\n }\n /* La projection locale ne décide plus de l'autorisation : SQL résout\n legacy via command_surface. Elle sert uniquement à adapter le payload. */\n const command = COMMAND_MAP[legacy] || legacy;\n const data = object(dataValue);\n const payload = commandPayload(legacy, command, data, ctx);\n const key = text(data.idempotency_key, 200) || `cockpit-${tenant(ctx)}-${command}-${crypto.randomUUID()}`;\n try {\n const result = await edgeRequest(\"command.execute\", {\n tenant_id: tenant(ctx),\n command: legacy,\n idempotency_key: key,\n command_payload: payload,\n });\n return normalizePlatformCommandResult(result);\n } catch (error) {\n const failure = error as Error & { status?: number; result?: Json };\n return {\n ...(failure.result || {}),\n ok: false,\n success: false,\n action_completed: false,\n execution_state: \"failed\",\n safe_to_announce: false,\n error: failure.message || \"platform_command_failed\",\n http_status: failure.status || 500,\n source_of_truth: \"supabase\",\n n8n_execution_used: false,\n };\n }\n}\n\n\n// Extension à ajouter à lib/platform-api-v31.ts sur Val Town.\nexport const PLATFORM_KERNEL_RELEASE = \"92.0.0-native-command-registry\";\nexport const PLATFORM_KERNEL_V91_RELEASE = \"91.0.0-universal-kernel\";\n\nconst KERNEL_COMMANDS_V91 = new Set([\n \"request.create\",\n \"appointment.book\",\n \"quote.draft\",\n \"request.status.update\",\n \"commitment.create\",\n]);\n\nfunction kernelActorV91(ctx: Json): Json {\n const role = text(ctx.role, 40).toLowerCase();\n if (![\"owner\", \"admin\"].includes(role)) throw new Error(\"owner_role_required\");\n const staffId = text(ctx.staff_id || ctx.actor_id, 80).toLowerCase();\n const authUserId = text(ctx.auth_user_id, 80).toLowerCase();\n if (!/^[0-9a-f-]{36}$/.test(staffId) || !/^[0-9a-f-]{36}$/.test(authUserId)) {\n throw new Error(\"authenticated_actor_required\");\n }\n return {\n staff_id: staffId,\n auth_user_id: authUserId,\n role,\n correlation_id: text(ctx.correlation_id, 200) || `cockpit-v91-${crypto.randomUUID()}`,\n origin: \"authenticated_cockpit\",\n };\n}\n\nexport async function platformKernelSnapshotV91(\n ctx: Json,\n serviceCaseIdValue: unknown = null,\n): Promise {\n const serviceCaseId = text(serviceCaseIdValue, 80).toLowerCase();\n if (serviceCaseId && !/^[0-9a-f-]{36}$/.test(serviceCaseId)) {\n throw new Error(\"invalid_service_case_id\");\n }\n return edgeRequest(\"bootstrap\", {\n kernel_version: \"91.0\",\n tenant_id: tenant(ctx),\n service_case_id: serviceCaseId || null,\n actor: kernelActorV91(ctx),\n });\n}\n\nexport async function platformKernelExecuteV91(\n ctx: Json,\n commandCodeValue: unknown,\n idempotencyKeyValue: unknown,\n payloadValue: unknown,\n): Promise {\n const commandCode = text(commandCodeValue, 100).toLowerCase();\n if (!KERNEL_COMMANDS_V91.has(commandCode)) throw new Error(\"kernel_command_not_allowed\");\n const idempotencyKey = text(idempotencyKeyValue, 200)\n || `cockpit-v91-${tenant(ctx)}-${commandCode}-${crypto.randomUUID()}`;\n if (!/^[a-zA-Z0-9][a-zA-Z0-9_.:-]{7,199}$/.test(idempotencyKey)) {\n throw new Error(\"invalid_idempotency_key\");\n }\n const result = await edgeRequest(\"command.execute\", {\n kernel_version: \"91.0\",\n tenant_id: tenant(ctx),\n command_code: commandCode,\n idempotency_key: idempotencyKey,\n payload: object(payloadValue),\n actor: kernelActorV91(ctx),\n execution_mode: \"active_internal\",\n });\n return {\n ...result,\n kernel_version: \"91.0\",\n source_of_truth: \"supabase\",\n n8n_execution_used: false,\n external_effects_performed: false,\n };\n}\n\nexport async function platformKernelTransitionV91(\n ctx: Json,\n commandCodeValue: unknown,\n toStatusValue: unknown,\n reasonValue: unknown,\n): Promise {\n const commandCode = text(commandCodeValue, 100).toLowerCase();\n if (!KERNEL_COMMANDS_V91.has(commandCode)) throw new Error(\"kernel_command_not_allowed\");\n const toStatus = text(toStatusValue, 40).toLowerCase();\n if (![\"paused\", \"rolled_back\"].includes(toStatus)) {\n throw new Error(\"owner_admin_action_limited_to_pause_or_rollback\");\n }\n return edgeRequest(\"command.execute\", {\n kernel_version: \"91.0\",\n admin_action: \"route.transition\",\n tenant_id: tenant(ctx),\n command_code: commandCode,\n to_status: toStatus,\n reason: text(reasonValue, 300) || \"Owner controlled stop from cockpit V91\",\n actor: kernelActorV91(ctx),\n });\n}\n\n\n// V92 — client du registre natif. La base reste l’unique autorité pour les commandes.\nexport const PLATFORM_KERNEL_V92_RELEASE = \"92.0.0-native-command-registry\";\n\nfunction kernelActorV92(ctx: Json): Json {\n const role = text(ctx.role, 40).toLowerCase();\n if (![\"owner\", \"admin\"].includes(role)) throw new Error(\"owner_role_required\");\n const staffId = text(ctx.staff_id || ctx.actor_id, 80).toLowerCase();\n const authUserId = text(ctx.auth_user_id, 80).toLowerCase();\n if (!/^[0-9a-f-]{36}$/.test(staffId) || !/^[0-9a-f-]{36}$/.test(authUserId)) {\n throw new Error(\"authenticated_actor_required\");\n }\n return {\n staff_id: staffId,\n auth_user_id: authUserId,\n role,\n correlation_id: text(ctx.correlation_id, 200) || `cockpit-v92-${crypto.randomUUID()}`,\n origin: \"authenticated_cockpit_v92\",\n };\n}\n\nfunction kernelCommandCodeV92(value: unknown): string {\n const commandCode = text(value, 100).toLowerCase();\n if (!/^[a-z][a-z0-9_.]{2,99}$/.test(commandCode)) {\n throw new Error(\"kernel_command_code_invalid\");\n }\n return commandCode;\n}\n\nexport async function platformKernelSnapshotV92(\n ctx: Json,\n serviceCaseIdValue: unknown = null,\n): Promise {\n const serviceCaseId = text(serviceCaseIdValue, 80).toLowerCase();\n if (serviceCaseId && !/^[0-9a-f-]{36}$/.test(serviceCaseId)) {\n throw new Error(\"invalid_service_case_id\");\n }\n const result = await edgeRequest(\"bootstrap\", {\n kernel_version: \"92.0\",\n tenant_id: tenant(ctx),\n service_case_id: serviceCaseId || null,\n actor: kernelActorV92(ctx),\n });\n return {\n ...result,\n kernel_version: \"92.0\",\n registry_source: \"kernel_command_registry_v92\",\n source_of_truth: \"supabase\",\n n8n_execution_used: false,\n external_effects_performed: false,\n };\n}\n\nexport async function platformKernelExecuteV92(\n ctx: Json,\n commandCodeValue: unknown,\n idempotencyKeyValue: unknown,\n payloadValue: unknown,\n): Promise {\n const commandCode = kernelCommandCodeV92(commandCodeValue);\n const idempotencyKey = text(idempotencyKeyValue, 200)\n || `cockpit-v92-${tenant(ctx)}-${commandCode}-${crypto.randomUUID()}`;\n if (!/^[a-zA-Z0-9][a-zA-Z0-9_.:-]{7,199}$/.test(idempotencyKey)) {\n throw new Error(\"invalid_idempotency_key\");\n }\n const result = await edgeRequest(\"command.execute\", {\n kernel_version: \"92.0\",\n tenant_id: tenant(ctx),\n command_code: commandCode,\n idempotency_key: idempotencyKey,\n payload: object(payloadValue),\n actor: kernelActorV92(ctx),\n execution_mode: \"active_internal\",\n });\n return {\n ...result,\n kernel_version: \"92.0\",\n registry_source: \"kernel_command_registry_v92\",\n source_of_truth: \"supabase\",\n n8n_execution_used: false,\n external_effects_performed: false,\n };\n}\n\nexport async function platformKernelTransitionV92(\n ctx: Json,\n commandCodeValue: unknown,\n toStatusValue: unknown,\n reasonValue: unknown,\n): Promise {\n const commandCode = kernelCommandCodeV92(commandCodeValue);\n const toStatus = text(toStatusValue, 40).toLowerCase();\n if (![\"paused\", \"rolled_back\"].includes(toStatus)) {\n throw new Error(\"owner_admin_action_limited_to_pause_or_rollback\");\n }\n return edgeRequest(\"command.execute\", {\n kernel_version: \"92.0\",\n admin_action: \"route.transition\",\n tenant_id: tenant(ctx),\n command_code: commandCode,\n to_status: toStatus,\n reason: text(reasonValue, 300) || \"Owner controlled stop from cockpit V92\",\n actor: kernelActorV92(ctx),\n });\n}\n","deleted",false,"label",[47,24],"lib","c92dbf10-5379-4f27-826a-f88beea36657",["D",1783720739803],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Plateforme multi-métiers de secrétariat IA autonome","imageUrl","userId","b09e2b61-6d3d-45b4-9e47-483ceda2d63e","pinnedFileId","66ce4ade-7caf-11f1-8983-1607ee4eb77e","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","019ee2d0-01b3-7462-a636-aad0cd2ecdf7","tursoName","c92dbf1053794f27826af88beea36657","tursoHostname","c92dbf1053794f27826af88beea36657-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789526460011],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_9":10,"_109":105},"org",{"_9":10,"_102":103,"_104":105,"_58":59,"_106":107,"_108":44},"branch",{"_37":92,"_11":93,"_22":30,"_94":48,"_95":-5,"_96":-5,"_97":-5,"_98":-5,"_99":-5,"_100":12,"_101":10},"isOwned",312,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","Lucas Bondi","avatar","https://lh3.googleusercontent.com/a/ACg8ocIOtmCQ3C5EHjNcuLBRZYhIsU0zzV95ucDS8yMqXk591M_byQ=s96-c","tier","free","canRestrictVals","profileImageUrl","ctx",{"_85":-5,"_143":144,"_145":146,"_147":148,"_149":44,"_150":44,"_151":44,"_152":34,"_153":-5,"_154":-7,"_155":-7,"_156":66,"_157":44,"_158":44,"_159":-5,"_160":44,"_161":44,"_162":44,"_163":-5},"ENV",{"_114":115,"_116":117,"_118":93,"_119":120,"_121":122,"_123":124,"_125":126,"_127":128,"_129":130,"_131":132,"_133":134,"_135":136,"_137":138,"_139":140,"_141":142},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","5015b8df46402d8bba4f485ecc37aec202b0e06b","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","orgs",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]