[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_168":169,"_170":171},"routes/_app.x.$handle.$name",{"_95":94,"_32":45,"_104":85,"_27":53,"_13":14,"_105":-5,"_11":106,"_107":108,"_109":110,"_111":112,"_113":114,"_20":-5,"_115":-5,"_116":-5,"_117":25,"_118":119,"_120":25,"_121":-5,"_122":-5,"_123":124},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_43":44,"_32":45,"_38":46,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":-5,"_57":25,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":-5,"_65":-5,"_66":-5,"_67":-5,"_68":69,"_70":69,"_71":72,"_73":72,"_74":72,"_75":69,"_76":69,"_77":78,"_79":80,"_81":82,"_83":25},"version",26,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":34,"_35":37,"_38":39,"_40":14,"_41":42,"_24":25},"previous",{"_30":31,"_32":28,"_33":34,"_35":36},"deleted",false,"deletedHere","path","promptGuard.ts","latestPath","fileId","dcf08d2a-9e61-11f1-9f34-1607ee4eb77e","name","fileType","script","content","// promptGuard.ts — CONFIGURAȚIA ÎNGHEȚATĂ. Se repune singură și spune CINE a schimbat-o.\n//\n// Referința e blobul `config_canonic`: promptul, modelul, vocea, mesajele fixe,\n// planurile de vorbire ȘI setările celor cinci tool-uri (mesaje + timeout).\n// Orice abatere e pusă la loc la următoarea tură de cron, iar owner-ul primește\n// pe mail ora și ORIGINEA scrierii, citite din logul de API al Vapi.\n//\n// De ce: pe 22 august configurația a fost suprascrisă de șase ori în două ore,\n// de fiecare dată din `https://dashboard.vapi.ai` — un tab lăsat deschis, care\n// la salvare republică draftul din pagina lui peste ce s-a pus prin API.\n//\n// CA SĂ SCHIMBI CEVA INTENȚIONAT: rescrie blobul `config_canonic`. Altfel\n// paznicul pune la loc versiunea de referință.\nimport { blob } from \"https://esm.town/v/std/blob\";\n\nconst FEREASTRA_MIN = 90;\nconst PAUZA_ALERTA_MIN = 10;\n\nconst egal = (a: unknown, b: unknown) => JSON.stringify(a ?? null) === JSON.stringify(b ?? null);\n\nasync function cineAScris(cheie: string, assistantId: string): Promise {\n try {\n const r = await fetch(\"https://api.vapi.ai/logs?type=API&limit=1000\", {\n headers: { Authorization: `Bearer ${cheie}` }, signal: AbortSignal.timeout(20000),\n });\n if (!r.ok) return [];\n const j = await r.json();\n const limita = Date.now() - FEREASTRA_MIN * 60_000;\n return (j?.results ?? [])\n .filter((x: any) => [\"PATCH\", \"PUT\", \"POST\"].includes(String(x?.requestHttpMethod)) &&\n String(x?.requestUrl ?? \"\").includes(assistantId) &&\n Date.parse(String(x?.time).replace(\" \", \"T\") + \"Z\") > limita)\n .sort((a: any, b: any) => String(a.time).localeCompare(String(b.time)))\n .map((x: any) => ` ${x.time} ${x.requestHttpMethod} ${x?.requestOrigin ? String(x.requestOrigin) : \"API (server, fără browser)\"}`);\n } catch { return []; }\n}\n\nexport async function pazestePromptul(probleme: string[]): Promise {\n const cfg: any = await blob.getJSON(\"noir_cfg\").catch(() => null);\n const ref: any = await blob.getJSON(\"config_canonic\").catch(() => null);\n if (!cfg?.vapiKey || !ref?.model?.messages?.[0]?.content) return;\n\n const H = { Authorization: `Bearer ${cfg.vapiKey}`, \"Content-Type\": \"application/json\" };\n const assistantId = ref.assistantId ?? cfg.assistantId;\n const adresa = `https://api.vapi.ai/assistant/${assistantId}`;\n\n const r = await fetch(adresa, { headers: H, signal: AbortSignal.timeout(15000) });\n if (!r.ok) return; // Vapi mut → nu tragem concluzii\n const a = await r.json();\n\n // ── ce s-a schimbat pe assistant ────────────────────────────────────────\n const CAMPURI = [\"voice\", \"firstMessage\", \"voicemailMessage\", \"endCallMessage\",\n \"stopSpeakingPlan\", \"startSpeakingPlan\", \"transcriber\", \"silenceTimeoutSeconds\"];\n const dif: string[] = [];\n const live = String(a?.model?.messages?.[0]?.content ?? \"\");\n const refPrompt = String(ref.model.messages[0].content);\n if (live !== refPrompt) dif.push(`prompt (${live.length} car., referință ${refPrompt.length})`);\n for (const k of [\"temperature\", \"maxTokens\", \"model\", \"provider\"]) {\n if (!egal(a?.model?.[k], ref.model[k])) dif.push(`model.${k} = ${JSON.stringify(a?.model?.[k])}`);\n }\n if (!egal([...(a?.model?.toolIds ?? [])].sort(), [...(ref.model.toolIds ?? [])].sort())) dif.push(\"model.toolIds\");\n for (const k of CAMPURI) if (ref[k] !== undefined && !egal(a?.[k], ref[k])) dif.push(k);\n\n const patch: Record = {};\n if (dif.some((d) => d.startsWith(\"prompt\") || d.startsWith(\"model.\"))) patch.model = ref.model;\n for (const k of CAMPURI) if (ref[k] !== undefined && !egal(a?.[k], ref[k])) patch[k] = ref[k];\n\n // ── ce s-a schimbat pe tool-uri ─────────────────────────────────────────\n const difTool: string[] = [];\n const deReparat: Array<[string, Record]> = [];\n for (const [id, t] of Object.entries(ref.tools ?? {})) {\n try {\n const rt = await fetch(`https://api.vapi.ai/tool/${id}`, { headers: H, signal: AbortSignal.timeout(12000) });\n if (!rt.ok) continue;\n const live = await rt.json();\n const p: Record = {};\n if (!egal(live?.messages ?? [], t.messages ?? [])) p.messages = t.messages ?? [];\n // Planul de extragere a variabilelor face pereche cu mesajul\n // `request-complete`: unul scoate fraza din răspunsul val-ului, celălalt o\n // rostește. Dacă rămâne păzit doar mesajul, o salvare din dashboard poate\n // șterge planul, mesajul rămâne pe loc, iar Vapi rostește la telefon chiar\n // textul „{{raspuns}}\". Se păzesc ÎMPREUNĂ sau deloc.\n if (t.variableExtractionPlan !== undefined &&\n !egal(live?.variableExtractionPlan, t.variableExtractionPlan))\n p.variableExtractionPlan = t.variableExtractionPlan;\n if (!egal(live?.timeoutSeconds, t.timeoutSeconds)) p.timeoutSeconds = t.timeoutSeconds;\n if (t.url && live?.url !== t.url) p.url = t.url;\n if (Object.keys(p).length) { difTool.push(`${t.name}: ${Object.keys(p).join(\", \")}`); deReparat.push([id, p]); }\n } catch { /* un tool necitit nu oprește restul */ }\n }\n\n if (!dif.length && !difTool.length) {\n await blob.setJSON(\"prompt_guard_stare\", { ok: true, la: new Date().toISOString() });\n return;\n }\n\n // ── repunem ─────────────────────────────────────────────────────────────\n let repus = true;\n if (Object.keys(patch).length) {\n try {\n const p = await fetch(adresa, { method: \"PATCH\", headers: H, body: JSON.stringify(patch), signal: AbortSignal.timeout(20000) });\n if (!p.ok) repus = false;\n } catch { repus = false; }\n }\n for (const [id, p] of deReparat) {\n try {\n const q = await fetch(`https://api.vapi.ai/tool/${id}`, { method: \"PATCH\", headers: H, body: JSON.stringify(p), signal: AbortSignal.timeout(12000) });\n if (!q.ok) repus = false;\n } catch { repus = false; }\n }\n\n const surse = await cineAScris(cfg.vapiKey, assistantId);\n const istoric: any[] = (await blob.getJSON(\"prompt_incidente\").catch(() => null)) ?? [];\n istoric.unshift({ la: new Date().toISOString(), dif, difTool, repus, surse });\n await blob.setJSON(\"prompt_incidente\", istoric.slice(0, 50));\n\n const ultima: any = await blob.getJSON(\"prompt_guard_alerta\").catch(() => null);\n const proaspata = ultima?.la && Date.now() - Date.parse(ultima.la) < PAUZA_ALERTA_MIN * 60_000;\n await blob.setJSON(\"prompt_guard_alerta\", { la: new Date().toISOString() });\n if (proaspata) return;\n\n probleme.push(\n \"CONFIGURAȚIA AGENTULUI A FOST SCHIMBATĂ\" +\n (repus ? \" — am pus-o la loc automat.\" : \" — NU am reușit să o pun la loc complet!\") +\n (dif.length ? \"\\n\\nPe assistant:\\n \" + dif.join(\"\\n \") : \"\") +\n (difTool.length ? \"\\n\\nPe tool-uri:\\n \" + difTool.join(\"\\n \") : \"\") +\n \"\\n\\nCINE A SCRIS în ultimele \" + FEREASTRA_MIN + \" de minute:\\n\" +\n (surse.length ? surse.join(\"\\n\") : \" (niciun log de scriere)\") +\n \"\\n\\n`https://dashboard.vapi.ai` = un tab de browser deschis pe assistant.\" +\n \"\\n`API (server, fără browser)` = scriere prin API.\" +\n \"\\n\\nDacă schimbarea e a ta și vrei s-o păstrezi, rescrie blobul `config_canonic`.\"\n );\n}\n","// promptGuard.ts — CONFIGURAȚIA ÎNGHEȚATĂ. Se repune singură și spune CINE a schimbat-o.\n//\n// Referința e blobul `config_canonic`: promptul, modelul, vocea, mesajele fixe,\n// planurile de vorbire ȘI setările celor cinci tool-uri (mesaje + timeout).\n// Orice abatere e pusă la loc la următoarea tură de cron, iar owner-ul primește\n// pe mail ora și ORIGINEA scrierii, citite din logul de API al Vapi.\n//\n// De ce: pe 22 august configurația a fost suprascrisă de șase ori în două ore,\n// de fiecare dată din `https://dashboard.vapi.ai` — un tab lăsat deschis, care\n// la salvare republică draftul din pagina lui peste ce s-a pus prin API.\n//\n// CA SĂ SCHIMBI CEVA INTENȚIONAT: rescrie blobul `config_canonic`. Altfel\n// paznicul pune la loc versiunea de referință.\nimport { blob } from \"https://esm.town/v/std/blob\";\n\nconst FEREASTRA_MIN = 90;\nconst PAUZA_ALERTA_MIN = 10;\n\nconst egal = (a: unknown, b: unknown) => JSON.stringify(a ?? null) === JSON.stringify(b ?? null);\n\nasync function cineAScris(cheie: string, assistantId: string): Promise {\n try {\n const r = await fetch(\"https://api.vapi.ai/logs?type=API&limit=1000\", {\n headers: { Authorization: `Bearer ${cheie}` }, signal: AbortSignal.timeout(20000),\n });\n if (!r.ok) return [];\n const j = await r.json();\n const limita = Date.now() - FEREASTRA_MIN * 60_000;\n return (j?.results ?? [])\n .filter((x: any) => [\"PATCH\", \"PUT\", \"POST\"].includes(String(x?.requestHttpMethod)) &&\n String(x?.requestUrl ?? \"\").includes(assistantId) &&\n Date.parse(String(x?.time).replace(\" \", \"T\") + \"Z\") > limita)\n .sort((a: any, b: any) => String(a.time).localeCompare(String(b.time)))\n .map((x: any) => ` ${x.time} ${x.requestHttpMethod} ${x?.requestOrigin ? String(x.requestOrigin) : \"API (server, fără browser)\"}`);\n } catch { return []; }\n}\n\nexport async function pazestePromptul(probleme: string[]): Promise {\n const cfg: any = await blob.getJSON(\"noir_cfg\").catch(() => null);\n const ref: any = await blob.getJSON(\"config_canonic\").catch(() => null);\n if (!cfg?.vapiKey || !ref?.model?.messages?.[0]?.content) return;\n\n const H = { Authorization: `Bearer ${cfg.vapiKey}`, \"Content-Type\": \"application/json\" };\n const assistantId = ref.assistantId ?? cfg.assistantId;\n const adresa = `https://api.vapi.ai/assistant/${assistantId}`;\n\n const r = await fetch(adresa, { headers: H, signal: AbortSignal.timeout(15000) });\n if (!r.ok) return; // Vapi mut → nu tragem concluzii\n const a = await r.json();\n\n // ── ce s-a schimbat pe assistant ────────────────────────────────────────\n const CAMPURI = [\"voice\", \"firstMessage\", \"voicemailMessage\", \"endCallMessage\",\n \"stopSpeakingPlan\", \"startSpeakingPlan\", \"transcriber\", \"silenceTimeoutSeconds\"];\n const dif: string[] = [];\n const live = String(a?.model?.messages?.[0]?.content ?? \"\");\n const refPrompt = String(ref.model.messages[0].content);\n if (live !== refPrompt) dif.push(`prompt (${live.length} car., referință ${refPrompt.length})`);\n // LLM-ul NU se mai păzește (4 sep 2026): furnizorul, modelul, temperatura și\n // maxTokens sunt alegerea lui Rareș, făcută din dashboard (OpenAI ↔ Anthropic,\n // pentru latență). Paznicul i le anula în sub un minut. Se păzesc în\n // continuare promptul, lista de tool-uri și restul configurației.\n if (!egal([...(a?.model?.toolIds ?? [])].sort(), [...(ref.model.toolIds ?? [])].sort())) dif.push(\"model.toolIds\");\n for (const k of CAMPURI) if (ref[k] !== undefined && !egal(a?.[k], ref[k])) dif.push(k);\n\n const patch: Record = {};\n // Repunem DOAR promptul și lista de tool-uri, peste modelul LIVE — altfel am\n // trimite înapoi și furnizorul din referință și i-am strica alegerea de LLM.\n if (dif.some((d) => d.startsWith(\"prompt\") || d.startsWith(\"model.\"))) {\n patch.model = { ...(a?.model ?? {}), messages: ref.model.messages, toolIds: ref.model.toolIds };\n }\n for (const k of CAMPURI) if (ref[k] !== undefined && !egal(a?.[k], ref[k])) patch[k] = ref[k];\n\n // ── ce s-a schimbat pe tool-uri ─────────────────────────────────────────\n const difTool: string[] = [];\n const deReparat: Array<[string, Record]> = [];\n for (const [id, t] of Object.entries(ref.tools ?? {})) {\n try {\n const rt = await fetch(`https://api.vapi.ai/tool/${id}`, { headers: H, signal: AbortSignal.timeout(12000) });\n if (!rt.ok) continue;\n const live = await rt.json();\n const p: Record = {};\n if (!egal(live?.messages ?? [], t.messages ?? [])) p.messages = t.messages ?? [];\n // Planul de extragere a variabilelor face pereche cu mesajul\n // `request-complete`: unul scoate fraza din răspunsul val-ului, celălalt o\n // rostește. Dacă rămâne păzit doar mesajul, o salvare din dashboard poate\n // șterge planul, mesajul rămâne pe loc, iar Vapi rostește la telefon chiar\n // textul „{{raspuns}}\". Se păzesc ÎMPREUNĂ sau deloc.\n if (t.variableExtractionPlan !== undefined &&\n !egal(live?.variableExtractionPlan, t.variableExtractionPlan))\n p.variableExtractionPlan = t.variableExtractionPlan;\n if (!egal(live?.timeoutSeconds, t.timeoutSeconds)) p.timeoutSeconds = t.timeoutSeconds;\n if (t.url && live?.url !== t.url) p.url = t.url;\n if (Object.keys(p).length) { difTool.push(`${t.name}: ${Object.keys(p).join(\", \")}`); deReparat.push([id, p]); }\n } catch { /* un tool necitit nu oprește restul */ }\n }\n\n if (!dif.length && !difTool.length) {\n await blob.setJSON(\"prompt_guard_stare\", { ok: true, la: new Date().toISOString() });\n return;\n }\n\n // ── repunem ─────────────────────────────────────────────────────────────\n let repus = true;\n if (Object.keys(patch).length) {\n try {\n const p = await fetch(adresa, { method: \"PATCH\", headers: H, body: JSON.stringify(patch), signal: AbortSignal.timeout(20000) });\n if (!p.ok) repus = false;\n } catch { repus = false; }\n }\n for (const [id, p] of deReparat) {\n try {\n const q = await fetch(`https://api.vapi.ai/tool/${id}`, { method: \"PATCH\", headers: H, body: JSON.stringify(p), signal: AbortSignal.timeout(12000) });\n if (!q.ok) repus = false;\n } catch { repus = false; }\n }\n\n const surse = await cineAScris(cfg.vapiKey, assistantId);\n const istoric: any[] = (await blob.getJSON(\"prompt_incidente\").catch(() => null)) ?? [];\n istoric.unshift({ la: new Date().toISOString(), dif, difTool, repus, surse });\n await blob.setJSON(\"prompt_incidente\", istoric.slice(0, 50));\n\n const ultima: any = await blob.getJSON(\"prompt_guard_alerta\").catch(() => null);\n const proaspata = ultima?.la && Date.now() - Date.parse(ultima.la) < PAUZA_ALERTA_MIN * 60_000;\n await blob.setJSON(\"prompt_guard_alerta\", { la: new Date().toISOString() });\n if (proaspata) return;\n\n probleme.push(\n \"CONFIGURAȚIA AGENTULUI A FOST SCHIMBATĂ\" +\n (repus ? \" — am pus-o la loc automat.\" : \" — NU am reușit să o pun la loc complet!\") +\n (dif.length ? \"\\n\\nPe assistant:\\n \" + dif.join(\"\\n \") : \"\") +\n (difTool.length ? \"\\n\\nPe tool-uri:\\n \" + difTool.join(\"\\n \") : \"\") +\n \"\\n\\nCINE A SCRIS în ultimele \" + FEREASTRA_MIN + \" de minute:\\n\" +\n (surse.length ? surse.join(\"\\n\") : \" (niciun log de scriere)\") +\n \"\\n\\n`https://dashboard.vapi.ai` = un tab de browser deschis pe assistant.\" +\n \"\\n`API (server, fără browser)` = scriere prin API.\" +\n \"\\n\\nDacă schimbarea e a ta și vrei s-o păstrezi, rescrie blobul `config_canonic`.\"\n );\n}\n","createdAt",["D",1788523423595],"branchVersion","branchId","7b5fd998-c785-4266-b0c5-cbdac545a089","id","5121b4f1-ae60-47dc-ae8b-0ff53766af7b","Cron",["D",1783866192781],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","","imageUrl","75ed5690-fa54-472c-8651-d2f3a765f22b","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","019f1e24-701b-74ed-856f-92f4f1031287","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_95":94,"_103":99},"org",{"_95":94,"_96":97,"_98":99,"_18":55,"_100":101,"_102":25},"branch",{"_13":84,"_32":85,"_43":42,"_86":44,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":45,"_93":94},"isOwned",27,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","sebastian1","handle","displayName","Sebastian","avatar","https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/ffb1b4b3-dadf-4ef0-553d-0a448a7fd000/square512?exp=1789556399&sig=913b2037b83be3ae9aef13be71e6a39ad664e7459313354273e845ef0031fec9","tier","free","canRestrictVals","profileImageUrl","branchName","adoptOrgId",{"_43":44,"_32":45,"_38":164,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":-5,"_57":25,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":-5,"_65":-5,"_66":-5,"_67":-5,"_68":69,"_70":69,"_71":72,"_73":72,"_74":72,"_75":69,"_76":69,"_77":165,"_79":166,"_81":167,"_83":25},"tree",[155,156],"files",[155,156],"counts",{"_144":61,"_145":146,"_147":61,"_148":149,"_150":151},"contents",[125,126],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_43":135,"_32":136,"_30":137,"_128":-5,"_41":42,"_40":138,"_129":25,"_38":139,"_13":140,"_33":141,"_35":142,"_24":25,"_133":-5,"_27":143},{"_43":127,"_32":28,"_30":31,"_128":-5,"_41":42,"_40":14,"_129":130,"_38":131,"_13":132,"_33":34,"_35":37,"_24":25,"_133":-5,"_27":134},"c1d5c3e1-b7fe-4e29-918f-8fa16bc5d69d","parentId","latest",true,["D",1788523423595],3,"label",[28],"3d7dc890-1f30-44e1-ad3b-c0d46c2e36c1","main.ts","36fed446-7dfd-11f1-82c9-1607ee4eb77e",25,["D",1788523422483],21,"interval","/* Open in Val Town: https://www.val.town/x/sebastian1/Cron/code/main.ts */\n/* Open in Val Town: https://www.val.town/x/sebastian1/Cron/code/main.ts */\n/* Open in Val Town: https://www.val.town/x/sebastian1/Cron/code/main.ts */\n// Cron (interval) — două joburi de fundal pentru Sofia, pe intervalul deja\n// configurat al val-ului:\n//\n// A) MONITOR de sănătate — la fiecare tură verifică dacă tool-urile răspund;\n// dacă ceva pică, trimite EMAIL la owner (o dată, la tranziție; fără spam).\n// De ce: pe 11 aug agentul a dat \"problemă tehnică\" (Google busy-times\n// timeout). Google e scos acum, dar orice defecțiune (Cal.com jos, val rupt,\n// config golit) trebuie aflată ÎNAINTE de o clientă.\n//\n// B) REMINDERE — seara (≥18:00 București), o dată pe zi (dedup prin blob),\n// găsește programările de MÂINE pe toate conturile Cal.com și trimite fiecărei\n// cliente un SMS de reamintire. Trimitere DEFENSIVĂ: prin SMSO dacă e cheie +\n// credite; altfel îți trimite ȚIE pe email lista, ca să reaminteşti manual.\n//\n// Alertele către owner = EMAIL nativ val.town (std/email → emailul contului):\n// gratis, fără credite, fără env. SMS-ul e DOAR pentru cliente (SMSO).\nimport { blob } from \"https://esm.town/v/std/blob\";\nimport { email } from \"https://esm.town/v/std/email\";\nimport { pazestePromptul } from \"./promptGuard.ts\";\nconst CHECK = \"https://sebastian1--8534c318924911f198f31607ee4eb77e.web.val.run\";\nconst GETTODAY = \"https://sebastian1--61668cb6755f11f1b80c1607ee4eb77e.web.val.run\";\nconst FIND = \"https://sebastian1--90bdff2876de11f18cb11607ee4eb77e.web.val.run\";\nconst BOOK = \"https://sebastian1--bc72f548755c11f1bb711607ee4eb77e.web.val.run\";\nconst CANCEL = \"https://sebastian1--c1114d9a76e011f18a0f1607ee4eb77e.web.val.run\";\nconst STATE_KEY = \"monitor_sofia_state\";\nconst REM_KEY = \"remindere_state\";\nconst APEL_KEY = \"monitor_apeluri_state\"; // santinela pe apeluri reale + canarul zilnic\n// Cheile Cal.com (owner/georges/fadileh/lavinia) — aceleași ca în celelalte vals.\nconst CHEI_CAL = [\n \"cal_live_123576c7fd8e27e38002e862d962fc71\",\n \"cal_live_1d9adfdb3c00a24517745eeefea82d4d\",\n \"cal_live_aea5843ab6d66cb3c9aa265f7be1a8d1\",\n \"cal_live_c33452303fada7bfcf9d48ac72190842\",\n];\nconst TZ = \"Europe/Bucharest\";\nasync function post(url, body, ms = 12000) {\n const r = await fetch(url, {\n method: \"POST\", headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify(body), signal: AbortSignal.timeout(ms),\n });\n return { status: r.status, txt: await r.text() };\n}\nfunction verificaViu(nume, status, txt, probleme) {\n if (status >= 500)\n probleme.push(`${nume} HTTP ${status}`);\n else if (/val not found/i.test(txt))\n probleme.push(`${nume}: Val not found (endpoint rupt)`);\n else {\n try {\n JSON.parse(txt);\n }\n catch {\n probleme.push(`${nume}: raspuns non-JSON`);\n }\n }\n}\nasync function alerteaza(subiect, text) {\n try {\n await email({ subject: subiect, text });\n console.log(\"EMAIL trimis:\", subiect);\n }\n catch (e) {\n console.error(\"EMAIL ERROR\", e);\n }\n}\n// ─── A) MONITOR ──────────────────────────────────────────────────────────────\nasync function ruleazaMonitor() {\n const probleme = [];\n const prev = (await blob.getJSON(STATE_KEY).catch(() => null)) || { broken: false, since: null, lastDeep: 0 };\n const usoare = [\n [\"getToday\", GETTODAY, { warmup: true }],\n [\"bookAppointment\", BOOK, {}],\n [\"cancelBooking\", CANCEL, {}],\n ];\n for (const [nume, url, body] of usoare) {\n try {\n const { status, txt } = await post(url, body);\n verificaViu(nume, status, txt, probleme);\n }\n catch (e) {\n probleme.push(`${nume} inaccesibil: ${e}`);\n }\n }\n const acumMs = Date.now();\n const deepDue = acumMs - (prev.lastDeep || 0) > 10 * 60 * 1000;\n let lastDeep = prev.lastDeep || 0;\n if (deepDue) {\n lastDeep = acumMs;\n try {\n const pana = new Date(acumMs + 7 * 864e5).toISOString();\n const { status, txt } = await post(CHECK, {\n startUtc: new Date(acumMs).toISOString(), endUtc: pana, service: \"Manichiură clasică\",\n }, 20000);\n if (status !== 200)\n probleme.push(`checkAvailability HTTP ${status}`);\n else {\n let j = null;\n try {\n j = JSON.parse(txt);\n }\n catch {\n probleme.push(\"checkAvailability raspuns invalid\");\n }\n if (j) {\n if (j.eroare)\n probleme.push(`checkAvailability eroare: ${j.eroare}`);\n const zile = j.zileDisponibile || [];\n const ore = (j.oreLocale || j.oreDeRostit || []);\n if (!j.eroare && zile.length === 0 && ore.length === 0)\n probleme.push(\"checkAvailability: 0 disponibilitate pe 7 zile (posibil program/config rupt)\");\n }\n }\n }\n catch (e) {\n probleme.push(`checkAvailability inaccesibil: ${e}`);\n }\n try {\n const { status, txt } = await post(FIND, { attendeeName: \"__monitor__\" });\n verificaViu(\"findBooking\", status, txt, probleme);\n }\n catch (e) {\n probleme.push(`findBooking inaccesibil: ${e}`);\n }\n }\n // Santinela pe apeluri reale (fiecare tură) + canarul de rezervare (o dată pe\n // zi). Amândouă adaugă în `probleme`, deci intră în aceeași alertă prin email\n // ca restul — fără canal nou, fără spam: doar la TRANZIȚIE.\n const stareApel = (await blob.getJSON(APEL_KEY).catch(() => null)) || { vazute: [], lastCanar: 0 };\n let vazute = stareApel.vazute ?? [];\n try {\n vazute = await santinelaApeluri(probleme, vazute);\n }\n catch (e) {\n console.error(\"SANTINELA ERROR\", e);\n }\n try {\n await verificaVapi(probleme);\n // Paznicul repune configurația dacă o suprascrie cineva, și spune ORIGINEA.\n // Din 4 sep 2026 NU mai păzește LLM-ul (provider/model/temperature/maxTokens)\n // — acelea sunt alegerea lui Rareș, din dashboard. Referința se rescrie cu\n // `node ~/Desktop/Sofia-REDEPLOY/salveaza-canonic.mjs`.\n await pazestePromptul(probleme).catch((e) => console.error(\"PROMPT GUARD\", String(e)));\n await pazesteRostirea(probleme).catch((e) => console.error(\"ROSTIRE GUARD\", String(e)));\n await incalzesteRaportul();\n }\n catch (e) {\n console.error(\"VERIFICA VAPI ERROR\", e);\n }\n let lastCanar = stareApel.lastCanar ?? 0;\n if (Date.now() - lastCanar > 20 * 60 * 60 * 1000) {\n lastCanar = Date.now();\n try {\n await canarRezervare(probleme);\n }\n catch (e) {\n probleme.push(`canar inaccesibil: ${e}`);\n }\n }\n await blob.setJSON(APEL_KEY, { vazute, lastCanar });\n const acumBroken = probleme.length > 0;\n const stamp = new Date().toISOString().slice(0, 16).replace(\"T\", \" \") + \" UTC\";\n if (acumBroken && !prev.broken) {\n await alerteaza(`[MONITOR SOFIA] PROBLEMĂ — agentul poate da erori`, `Detectat ${stamp}:\\n\\n• ${probleme.join(\"\\n• \")}\\n\\nAgentul poate da erori clientelor. Verifică val-urile / Cal.com.`);\n }\n else if (!acumBroken && prev.broken) {\n await alerteaza(`[MONITOR SOFIA] Revenit la normal`, `La ${stamp} toate tool-urile răspund OK din nou.`);\n }\n await blob.setJSON(STATE_KEY, { broken: acumBroken, since: acumBroken ? (prev.since || stamp) : null, lastDeep, ultimele: probleme, updatedAt: stamp });\n console.log(\"MONITOR\", acumBroken ? \"BROKEN: \" + probleme.join(\"; \") : \"OK\", deepDue ? \"(deep)\" : \"(light)\");\n}\n// ─── C) SANTINELĂ PE APELURI REALE ───────────────────────────────────────────\n// Monitorul de mai sus verifică dacă tool-urile RĂSPUND. Asta nu ajunge: pot\n// răspunde perfect (HTTP 200) și totuși să refuze o clientă adevărată fiindcă\n// modelul a trimis payload-ul în altă formă decât aștepta val-ul. S-a întâmplat\n// de două ori — 9 aug („Serviciul lipsește\", `servicii` trimis ca text) și\n// 16 aug („Data de start lipsește\", lanț trimis fără `start`) — iar clienta a\n// auzit „am o mică problemă tehnică\". Nimeni nu află, dacă nu deschide Vapi.\n// Deci: la fiecare tură citim apelurile recente și căutăm refuzuri TEHNICE\n// (contract rupt), nu motive de business („ora s-a ocupat\" e normal).\nconst RE_TEHNIC = /lipse[șs]te|nu am primit|format|invalid|eroare intern|agenda nu a putut fi citit/i;\nasync function santinelaApeluri(probleme, vazute) {\n const cfg = (await blob.getJSON(\"noir_cfg\").catch(() => null));\n const cheie = cfg?.vapiKey;\n if (!cheie)\n return vazute;\n const r = await fetch(\"https://api.vapi.ai/call?limit=20\", {\n headers: { Authorization: `Bearer ${cheie}` }, signal: AbortSignal.timeout(15000),\n });\n if (!r.ok)\n return vazute;\n const apeluri = await r.json();\n const noiVazute = [...vazute];\n for (const c of (Array.isArray(apeluri) ? apeluri : [])) {\n if (vazute.includes(c.id))\n continue;\n // apelurile în desfășurare nu se judecă încă\n if (String(c.status) !== \"ended\")\n continue;\n const msgs = c.messages || c.artifact?.messages || [];\n const gasite = [];\n // AFIRMAȚIE DESPRE AGENDĂ FĂRĂ VERIFICARE.\n // Vapi nu permite forțarea unui apel de tool, deci codul nu poate opri\n // modelul să vorbească. Ce poate face: să prindă FIECARE abatere și să o\n // raporteze. Pe 22 august agentul a spus „miercuri la ora zece am liber\n // pentru șuvițe\" fără să verifice — Georges vine miercuri abia de la unu.\n // Regula era deja în prompt, pe primul loc, și tot a fost încălcată.\n {\n const spuneLiber = /\\b(am liber|e liber(ă)?|este liber(ă)?|mai am loc|vă pot programa|se poate (atunci|la ora))\\b/i;\n let ultimaVerificare = -1, i = 0;\n for (const m of msgs) {\n if (m.role === \"tool_calls\" &&\n (m.toolCalls || []).some((t) => /checkAvailability/i.test(t?.function?.name ?? \"\")))\n ultimaVerificare = i;\n if (m.role === \"bot\" && spuneLiber.test(String(m.message ?? \"\"))) {\n // „proaspăt\" = verificarea e cel mult cu două mesaje înainte\n // (apelul tool-ului + rezultatul lui), adică în aceeași tură.\n if (ultimaVerificare < 0 || i - ultimaVerificare > 3) {\n gasite.push(`a spus că e liber FĂRĂ verificare în aceeași tură: «${String(m.message ?? \"\").slice(0, 110)}»`);\n break;\n }\n }\n i++;\n }\n }\n // FRAZA ROSTITĂ ≠ FRAZA TRIMISĂ DE COD.\n // Dovada că mecanismul chiar merge se ia din apeluri ADEVĂRATE, nu din\n // configurație: dacă mesajul `request-complete` e scos din tool, Vapi nu\n // dă nicio eroare — pur și simplu lasă iar modelul să compună fraza, iar\n // orele inventate se întorc fără ca nimeni să observe. Aici comparăm ce a\n // trimis val-ul cu ce a rostit agentul imediat după.\n {\n const curat = (x) => String(x ?? \"\").toLowerCase()\n .normalize(\"NFD\").replace(/[\\u0300-\\u036f]/g, \"\")\n .replace(/[^a-z0-9]+/g, \" \").trim();\n for (let i = 0; i < msgs.length; i++) {\n const m = msgs[i];\n if (m.role !== \"tool_call_result\" || !/checkAvailability/i.test(String(m.name ?? \"\")))\n continue;\n let fraza = \"\";\n try {\n fraza = JSON.parse(String(m.result ?? \"{}\"))?.raspuns ?? \"\";\n }\n catch { continue; }\n if (!fraza)\n continue;\n const rostit = msgs.slice(i + 1).find((x) => x.role === \"bot\" && String(x.message ?? \"\").trim());\n if (!rostit)\n continue;\n if (!curat(rostit.message).includes(curat(fraza))) {\n gasite.push(\"agentul NU a rostit fraza trimisă de cod — a compus-o singur, deci poate inventa ore.\" +\n `\\n cod: «${fraza.slice(0, 130)}»` +\n `\\n rostit: «${String(rostit.message).slice(0, 130)}»` +\n \"\\n se repară cu: node ~/Desktop/Sofia-REDEPLOY/vapi-rostire.mjs\");\n break;\n }\n }\n }\n for (const m of msgs) {\n if (m.role !== \"tool_call_result\")\n continue;\n const txt = String(m.result ?? \"\");\n if (!/\"ok\"\\s*:\\s*false/.test(txt) && !/\"eroare\"/.test(txt))\n continue;\n const motiv = (txt.match(/\"error\"\\s*:\\s*\"([^\"]{0,140})\"/) ?? txt.match(/\"eroare\"\\s*:\\s*\"([^\"]{0,140})\"/) ?? [])[1] ?? \"\";\n if (motiv && RE_TEHNIC.test(motiv))\n gasite.push(`${m.name ?? \"tool\"}: ${motiv}`);\n }\n // Simptome pe care le vede CLIENTA, nu doar tool-urile: aceeași replică\n // spusă de două ori la rând (filler dublat — o dată de model, o dată de\n // mesajul automat al tool-ului) și fraza de eșec „mică problemă tehnică\".\n // Amândouă s-au auzit într-un apel real pe 16 aug.\n const spuse = msgs\n .filter((m) => m.role === \"bot\" && m.message)\n .map((m) => String(m.message).toLowerCase().replace(/[^a-zăâîșț ]/g, \"\").trim());\n for (let i = 1; i < spuse.length; i++) {\n if (spuse[i] && spuse[i] === spuse[i - 1]) {\n gasite.push(`replică repetată identic: „${spuse[i].slice(0, 60)}\"`);\n break;\n }\n }\n if (spuse.some((t) => /problem[ăa] tehnic/.test(t)))\n gasite.push(\"agentul i-a spus clientei că are o problemă tehnică\");\n noiVazute.push(c.id);\n if (gasite.length) {\n probleme.push(`APEL REAL refuzat tehnic (${String(c.createdAt).slice(0, 16)}, ${c.customer?.number ?? \"web\"}): ${[...new Set(gasite)].join(\" | \")}`);\n }\n }\n return noiVazute.slice(-60); // păstrăm doar coada recentă, ca blobul să nu crească\n}\n// ─── C2) CONFIGURAȚIA VAPI SE REPARĂ SINGURĂ ────────────────────────────────\n// De trei ori (16 aug: v71, v73, v77) promptul live s-a întors la o versiune\n// veche, iar istoricul Vapi arată de fiecare dată același autor: contul din\n// dashboard. Un tab Vapi lăsat deschis republică, la salvare, draftul pe care\n// îl are el în pagină — peste ce am pus prin API. Nimic nu se vede: tool-urile\n// răspund, val-urile merg, dar agentul vorbește după reguli vechi (înșiră toate\n// orele, spune „cu drag, vă așteptăm\"). Clientul află din apel, ceea ce e prea\n// târziu.\n//\n// Până acum doar semnalam. Acum REPARĂM: comparăm live-ul cu referința din\n// blobul `vapi_canonic` și, dacă diferă, punem referința la loc pe loc, apoi\n// anunțăm ce s-a schimbat și că a fost repus. Fereastra în care agentul poate\n// vorbi după reguli vechi scade la o tură de cron.\n//\n// Referința se rescrie DOAR intenționat: node ~/Desktop/Sofia-REDEPLOY/vapi-canonic.mjs\nconst CAMPURI_PAZITE = [\"transcriber\", \"startSpeakingPlan\", \"stopSpeakingPlan\", \"backgroundSpeechDenoisingPlan\", \"voice\"];\n// Ține raportul cald. Memoria temporară a dashboard-ului ține 5 minute; cine\n// intra fix după expirare aștepta adunarea a până la 1000 de apeluri din Vapi.\n// Cronul o reîmprospătează el, deci salonul găsește mereu raportul gata făcut.\nasync function incalzesteRaportul() {\n try {\n const cfg = await blob.getJSON(\"noir_cfg\").catch(() => null);\n if (!cfg?.token)\n return;\n await fetch(`https://sebastian1--06410ad4974a11f195461607ee4eb77e.web.val.run?data=1&t=${encodeURIComponent(cfg.token)}`, { signal: AbortSignal.timeout(45000) });\n }\n catch (e) { /* dacă nu merge, se încarcă la cerere, ca înainte */ }\n}\nasync function verificaVapi(probleme) {\n const cfg = (await blob.getJSON(\"noir_cfg\").catch(() => null));\n const canonic = (await blob.getJSON(\"vapi_canonic\").catch(() => null));\n if (!cfg?.vapiKey || !canonic?.transcriber)\n return;\n const H = { Authorization: `Bearer ${cfg.vapiKey}`, \"Content-Type\": \"application/json\" };\n const adresa = `https://api.vapi.ai/assistant/${cfg.assistantId}`;\n const r = await fetch(adresa, { headers: H, signal: AbortSignal.timeout(15000) });\n if (!r.ok)\n return;\n const a = await r.json();\n // Promptul NU se mai păzește. E al lui Rareș și îl schimbă din dashboard când\n // vrea; paznicul i-l ștergea peste. Aici rămâne doar sunetul.\n const dif = [];\n for (const k of CAMPURI_PAZITE) {\n if (!canonic[k])\n continue;\n if (JSON.stringify(a[k] ?? null) !== JSON.stringify(canonic[k]))\n dif.push(k);\n }\n if (!dif.length)\n return;\n // NU mai reparăm automat. Paznicul doar ANUNȚĂ, iar decizia rămâne a lui Rareș.\n //\n // De ce s-a schimbat: repararea automată a fost gândită pentru cazul din 16\n // august, când promptul sărea singur la o versiune veche și nimeni nu afla.\n // Notificarea rezolvă exact acel risc. Repararea aducea în plus doar cele\n // ~15 minute până la tura următoare, dar în schimb călca peste schimbările\n // FĂCUTE INTENȚIONAT din dashboard — pe 19 august a pus Gemini înapoi peste\n // Soniox, alegerea corectă a lui Rareș. Un paznic care strică ce ai reparat\n // e mai rău decât niciunul.\n //\n // Ca să repui tu configurația de referință: node ~/Desktop/Sofia-REDEPLOY/vapi-canonic.mjs\n // Ca să accepți schimbarea ca fiind cea bună: node ~/Desktop/Sofia-REDEPLOY/vapi-canonic.mjs --doar-referinta\n const arata = (k) => {\n const acum = JSON.stringify(a[k] ?? null), ref = JSON.stringify(canonic[k] ?? null);\n const scurt = (x) => String(x).length > 150 ? String(x).slice(0, 150) + \"…\" : String(x);\n return `${k}\\n acum: ${scurt(acum)}\\n referință: ${scurt(ref)}`;\n };\n probleme.push(\"CONFIGURAȚIA AGENTULUI S-A SCHIMBAT\\n\\n\" +\n dif.map(arata).join(\"\\n\\n\") +\n \"\\n\\nNU am modificat nimic — decizi tu.\" +\n \"\\n· Dacă TU ai făcut schimbarea și e bună, rulează: node ~/Desktop/Sofia-REDEPLOY/vapi-canonic.mjs --doar-referinta\" +\n \"\\n· Dacă NU tu ai făcut-o, rulează: node ~/Desktop/Sofia-REDEPLOY/vapi-canonic.mjs\" +\n \"\\n· Dacă ai un tab Vapi deschis, închide-l: la salvare republică o versiune veche.\");\n}\n// ─── C2) PAZNIC PE ROSTIRE ───────────────────────────────────────────────────\n// Orele inventate au dispărut fiindcă fraza NU mai e compusă de model: val-ul o\n// trimite gata făcută, iar Vapi o citește cuvânt cu cuvânt prin mesajul\n// `request-complete` + `variableExtractionPlan`. Cele două setări stau în\n// tool-ul din Vapi, adică exact acolo unde o salvare din dashboard a suprascris\n// deja de trei ori configurația. Dacă dispar, nimic nu se strică vizibil —\n// agentul doar începe iar să compună ore, iar salonul află de la cliente.\n// De asta se verifică la fiecare tură. Ca peste tot: ANUNȚĂM, nu reparăm.\nconst TOOL_CHECK = \"0c728793-0be8-4192-b009-c970f7071436\";\nasync function pazesteRostirea(probleme) {\n const cfg = (await blob.getJSON(\"noir_cfg\").catch(() => null));\n if (!cfg?.vapiKey)\n return;\n const r = await fetch(`https://api.vapi.ai/tool/${TOOL_CHECK}`, {\n headers: { Authorization: `Bearer ${cfg.vapiKey}` },\n signal: AbortSignal.timeout(15000),\n });\n if (!r.ok)\n return;\n const t = await r.json();\n const lipsa = [];\n const m = (t.messages ?? []).find((x) => x?.type === \"request-complete\");\n if (!m || !String(m.content ?? \"\").includes(\"{{raspuns}}\"))\n lipsa.push(\"mesajul `request-complete` cu {{raspuns}}\");\n if (!t.variableExtractionPlan?.schema?.properties?.raspuns)\n lipsa.push(\"`variableExtractionPlan` cu câmpul raspuns\");\n if (!lipsa.length)\n return;\n probleme.push(\"AGENTUL POATE INVENTA IAR ORE\\n\\n\" +\n \"Din tool-ul checkAvailability lipsește: \" + lipsa.join(\" și \") + \".\\n\" +\n \"Fără ele, Vapi nu mai rostește fraza trimisă de cod, ci lasă modelul să o compună — \" +\n \"exact cauza orelor care nu existau în agendă.\\n\" +\n \"Se pune la loc cu: node ~/Desktop/Sofia-REDEPLOY/vapi-rostire.mjs\");\n}\n// ─── D) CANAR: o rezervare ADEVĂRATĂ pe zi, în forma în care o trimite modelul ─\n// Testele rulează când le rulez eu; canarul rulează singur. Face exact ce face\n// clienta — verifică, rezervă un lanț trimițându-l DOAR prin `programari` (fără\n// `start`, forma care a picat pe 16 aug), apoi anulează. Fără telefon → fără SMS.\n// Ziua e departe în viitor, ca să nu atingă agenda reală a salonului.\nasync function canarRezervare(probleme) {\n const peste = new Date(Date.now() + 45 * 864e5).toISOString().slice(0, 10);\n const { status, txt } = await post(CHECK, { startUtc: `${peste}T00:00:00Z`, service: \"pensat\", specialist: \"Fadileh\" }, 20000);\n if (status !== 200) {\n probleme.push(`canar: checkAvailability HTTP ${status}`);\n return;\n }\n let j = null;\n try {\n j = JSON.parse(txt);\n }\n catch {\n probleme.push(\"canar: check răspuns invalid\");\n return;\n }\n // Startul se ia GATA FĂCUT din `oreStartToate` (ISO complet). Câmpul `ore`\n // („09:00\") a fost scos din răspuns tocmai ca modelul să nu mai compună\n // singur data din oră — canarul nu are voie să o compună nici el.\n // Codurile de rezervare (`oreStartToate`, ISO complet) există DOAR pentru ziua\n // cerută. Zilele alternative vin cu orele în litere, fără cod — ca modelul să\n // nu le rostească drept cifre. Deci: dacă ziua cerută nu merge, canarul cere\n // din nou prima zi alternativă, exact cum trebuie să facă și agentul.\n let start = (j?.oreStartToate ?? [])[0];\n if (!start) {\n const alta = j?.zileDisponibile?.[0]?.zi;\n if (!alta) {\n probleme.push(\"canar: checkAvailability nu oferă nicio oră în 45 de zile\");\n return;\n }\n const a2 = await post(CHECK, { startUtc: `${alta}T00:00:00Z`, service: \"pensat\", specialist: \"Fadileh\" }, 20000);\n try {\n start = (JSON.parse(a2.txt)?.oreStartToate ?? [])[0];\n }\n catch { /* jos */ }\n if (!start) {\n probleme.push(`canar: ziua alternativă ${alta} nu întoarce niciun cod de rezervare`);\n return;\n }\n }\n // Fraza rostită de Vapi: verificată pe apel REAL, în fiecare zi. Dacă lipsește,\n // Vapi citește cu voce tare chiar textul „{{raspuns}}\"; dacă are cifre, vocea\n // le rostește greșit; dacă e din alt val, agentul e iar liber să inventeze ore.\n if (typeof j?.raspuns !== \"string\" || j.raspuns.trim().length < 10)\n probleme.push(\"canar: checkAvailability NU mai întoarce fraza `raspuns` — Vapi va rosti „{{raspuns}}\\\" sau va lăsa modelul să compună ore\");\n else if (/\\d/.test(j.raspuns))\n probleme.push(`canar: fraza rostită conține cifre, vocea le citește greșit: „${j.raspuns}\"`);\n const rez = await post(BOOK, {\n attendeeName: \"CANAR MONITOR\",\n programari: `${start} | pensat | Fadile`,\n }, 25000);\n let b = null;\n try {\n b = JSON.parse(rez.txt);\n }\n catch { /* jos */ }\n const uids = [...((b?.rezervari ?? []).map((x) => x.uid)), b?.uid].filter(Boolean);\n if (!b || b.ok !== true || !uids.length) {\n probleme.push(`canar: rezervarea a EȘUAT (${b?.error ?? rez.status}) — forma de payload a modelului nu mai e acceptată`);\n }\n if (uids.length) {\n const an = await post(CANCEL, { uids: uids.join(\",\") }, 20000);\n let a = null;\n try {\n a = JSON.parse(an.txt);\n }\n catch { /* jos */ }\n if (!a || a.ok !== true)\n probleme.push(`canar: anularea a eșuat (${a?.error ?? an.status}) — rămâne „${uids.join(\",\")}\" în calendar`);\n else\n console.log(\"CANAR ok:\", zi, ora, \"(rezervat + anulat)\");\n }\n}\n// ─── B) REMINDERE ────────────────────────────────────────────────────────────\nfunction partiBuch(d = new Date()) {\n const p = Object.fromEntries(new Intl.DateTimeFormat(\"en-CA\", { timeZone: TZ, year: \"numeric\", month: \"2-digit\", day: \"2-digit\", hour: \"2-digit\", minute: \"2-digit\", hour12: false })\n .formatToParts(d).map((x) => [x.type, x.value]));\n return { data: `${p.year}-${p.month}-${p.day}`, ora: Number(p.hour) };\n}\nfunction hhmm(iso) {\n return new Intl.DateTimeFormat(\"ro-RO\", { timeZone: TZ, hour: \"2-digit\", minute: \"2-digit\", hour12: false }).format(new Date(iso));\n}\nfunction normTel(raw) {\n let d = String(raw ?? \"\").replace(/[^\\d+]/g, \"\");\n if (d.startsWith(\"+\"))\n return d.length >= 11 ? d : \"\";\n const c = d.replace(/\\D/g, \"\");\n if (c.startsWith(\"40\"))\n return \"+\" + c;\n if (c.startsWith(\"0\"))\n return \"+40\" + c.slice(1);\n if (c.length >= 9)\n return \"+40\" + c;\n return \"\";\n}\nasync function bookingsPtZi(ziBuch) {\n const rez = [];\n const vazute = new Set();\n for (const k of CHEI_CAL) {\n try {\n const r = await fetch(\"https://api.cal.com/v2/bookings?status=upcoming&take=100\", {\n headers: { Authorization: `Bearer ${k}`, \"cal-api-version\": \"2024-08-13\" }, signal: AbortSignal.timeout(12000),\n });\n if (!r.ok)\n continue;\n const j = await r.json();\n for (const b of (j?.data ?? [])) {\n const st = String(b?.start ?? \"\");\n if (!st || [\"cancelled\", \"rejected\"].includes(String(b?.status ?? \"\").toLowerCase()))\n continue;\n if (partiBuch(new Date(st)).data !== ziBuch)\n continue;\n const uid = String(b?.uid ?? b?.id ?? st);\n if (vazute.has(uid))\n continue;\n vazute.add(uid);\n const at = (b?.attendees ?? [])[0] ?? {};\n const email = String(at?.email ?? \"\");\n const tel = at?.phoneNumber ?? (email.endsWith(\"@sms.cal.com\") ? email.split(\"@\")[0] : \"\");\n const serviciu = b?.eventType?.title ?? String(b?.title ?? \"\").split(/ between | cu /i)[0] ?? \"programarea\";\n rez.push({ uid, nume: String(at?.name ?? \"\"), tel: String(tel), serviciu: String(serviciu).trim() || \"programarea\", ora: hhmm(st) });\n }\n }\n catch { /* cont indisponibil → sar */ }\n }\n return rez;\n}\nasync function trimiteSMSO(to, body) {\n const key = Deno.env.get(\"SMSO_API_KEY\");\n if (!key)\n return { ok: false, motiv: \"fără SMSO_API_KEY în context\" };\n const ascii = body.normalize(\"NFD\").replace(/[̀-ͯ]/g, \"\");\n try {\n const r = await fetch(\"https://app.smso.ro/api/v1/send\", {\n method: \"POST\", headers: { \"X-Authorization\": key, \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ to, body: ascii }), signal: AbortSignal.timeout(10000),\n });\n const t = await r.text();\n return { ok: r.ok, motiv: r.ok ? \"\" : `SMSO ${r.status}: ${t.slice(0, 80)}` };\n }\n catch (e) {\n return { ok: false, motiv: String(e) };\n }\n}\nasync function ruleazaRemindere() {\n const acum = partiBuch();\n if (acum.ora < 18)\n return; // trimitem seara\n const st = (await blob.getJSON(REM_KEY).catch(() => null)) || { lastDate: null };\n if (st.lastDate === acum.data)\n return; // deja procesat azi\n const maine = partiBuch(new Date(Date.now() + 864e5)).data;\n const lista = await bookingsPtZi(maine);\n // marcăm ziua procesată ACUM (înainte de trimitere) ca să NU dublăm SMS-uri la\n // clientă dacă cron-ul se reia; eșecurile ajung pe email, nu se re-trimit.\n await blob.setJSON(REM_KEY, { lastDate: acum.data, maine, count: lista.length, procesatLa: new Date().toISOString() });\n if (lista.length === 0) {\n console.log(\"REMINDERE: 0 programări pt\", maine);\n return;\n }\n const trimise = [], esuate = [];\n for (const p of lista) {\n const tel = normTel(p.tel);\n if (!tel) {\n esuate.push({ ...p, motiv: \"fără telefon valid\" });\n continue;\n }\n const text = `Noir by Fadileh: va reamintim programarea de maine, ${p.serviciu} la ora ${p.ora}. Pentru modificari, sunati la salon.`;\n const r = await trimiteSMSO(tel, text);\n if (r.ok)\n trimise.push(p);\n else\n esuate.push({ ...p, motiv: r.motiv });\n }\n const linii = [`Programări mâine (${maine}): ${lista.length}. SMS reamintire trimise: ${trimise.length}.`];\n if (esuate.length) {\n linii.push(`\\n⚠️ NU s-a trimis SMS la ${esuate.length} — reaminteşte-le MANUAL (sau verifică credite SMSO):`);\n for (const e of esuate)\n linii.push(`• ${e.nume || \"?\"} — ${e.tel || \"fără tel\"} — ${e.serviciu} la ${e.ora} [${e.motiv}]`);\n }\n if (trimise.length) {\n linii.push(`\\n✅ Trimise:`);\n for (const t of trimise)\n linii.push(`• ${t.nume || \"?\"} — ${t.serviciu} la ${t.ora}`);\n }\n await alerteaza(`[SOFIA] Reamintiri mâine: ${trimise.length}/${lista.length} trimise`, linii.join(\"\\n\"));\n console.log(\"REMINDERE\", `${trimise.length}/${lista.length} trimise pt`, maine);\n}\nexport default async function () {\n await ruleazaMonitor();\n try {\n await ruleazaRemindere();\n }\n catch (e) {\n console.error(\"REMINDERE ERROR\", e);\n }\n}\n",[136],"pulls","branches",1,"forks","envVars",{"_152":61,"_154":61},"connections",{"_152":61,"_153":61},"count","unfilledCount","emptyCount",{"_43":135,"_32":136,"_30":137,"_128":-5,"_41":42,"_40":138,"_129":25,"_38":161,"_13":140,"_33":141,"_35":142,"_24":25,"_133":-5,"_158":162,"_27":163},{"_43":127,"_32":28,"_30":31,"_128":-5,"_41":42,"_40":14,"_129":130,"_38":157,"_13":132,"_33":34,"_35":37,"_24":25,"_133":-5,"_158":159,"_27":160},["D",1788523423595],"children",[],[28],["D",1788523422483],[],[136],["D",1783866192781],{"_95":94,"_103":99},{"_95":94,"_96":97,"_98":99,"_18":55,"_100":101,"_102":25},{"_13":84,"_32":85,"_43":42,"_86":44,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":45,"_93":94},"ctx",{"_77":-5,"_122":201,"_202":203,"_204":205,"_206":25,"_207":25,"_208":25,"_209":130,"_210":-5,"_211":-7,"_212":-7,"_213":61,"_214":25,"_215":25,"_216":-5,"_217":25,"_218":25,"_219":25,"_220":-5},"ENV",{"_172":173,"_174":175,"_176":85,"_177":178,"_179":180,"_181":182,"_183":184,"_185":186,"_187":188,"_189":190,"_191":192,"_193":194,"_195":196,"_197":198,"_199":200},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Diff · v26