[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_163":164,"_165":166},"routes/_app.x.$handle.$name",{"_105":104,"_38":51,"_112":95,"_33":59,"_13":14,"_113":-5,"_11":114,"_115":116,"_117":118,"_119":120,"_121":122,"_26":-5,"_123":-5,"_124":-5,"_125":31,"_126":127,"_128":64,"_129":-5,"_130":-5,"_131":132},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":18,"_19":-5},"project",{"_49":50,"_38":51,"_44":52,"_53":-5,"_54":31,"_55":56,"_57":56,"_58":59,"_60":-5,"_19":61,"_62":37,"_63":64,"_65":-5,"_66":-5,"_67":68,"_69":70,"_71":72,"_73":74,"_75":76,"_77":-5,"_78":79,"_80":79,"_81":82,"_83":82,"_84":82,"_85":79,"_86":79,"_87":88,"_89":90,"_91":92,"_93":31},"version",22,"changes",[25],"aiChatInfo",{"_20":21,"_22":-5,"_23":-5,"_24":-5},"userId","aiChatMessageId","88a89b78-ac3d-4940-8fb3-e0ca98b44317","aiChatThreadId","aiChatThreadUserId","aiChatThreadTitle",{"_26":27,"_28":29,"_30":31,"_32":31,"_33":34,"_35":34},"file",{"_36":37,"_38":34,"_39":40,"_41":43,"_44":45,"_46":14,"_47":48,"_30":31},"previous",{"_36":37,"_38":34,"_39":40,"_41":42},"deleted",false,"deletedHere","path","main.ts","latestPath","fileId","74a50e2a-b096-11f1-8116-1607ee4eb77e","name","fileType","http","content","\n// ============================================================\n// Yemot Phone Bot v5.1 - Ultimate Production Edition\n// ============================================================\n// Complete Feature Set:\n// • Hebrew AI phone bot with Groq GPT-OSS-120B\n// • Whisper Hebrew transcription\n// • Tavily search (auto + forced)\n// • Unlock code system with silent redaction\n// • 3-layer censorship + Canary token\n// • Response splitting for long answers\n// • Refusal detection + retry logic\n// • Optimized timeouts for Yemot limits\n// ============================================================\n\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\n// ═══════════════════════════════════════════════════════════\n// CONFIGURATION\n// ═══════════════════════════════════════════════════════════\n\nconst TIMEOUT_MS = 3500;\nconst SEARCH_TIMEOUT_MS = 1500;\nconst LLM_TIMEOUT_MS = 3500;\nconst CENSOR_TIMEOUT_MS = 1500;\n\nconst MAX_COMPLETION_TOKENS = 500;\nconst TAVILY_RESULTS = 2;\nconst TAVILY_CONTENT_MAX = 200;\n\nconst TTS_MAX_CHARS = 900;\nconst TTS_SPLIT_THRESHOLD = 1050;\n\nconst MAX_RETRIES = 2;\nconst INITIAL_RETRY_DELAY_MS = 500;\nconst MAX_RETRY_DELAY_MS = 2500;\n\n// ═══════════════════════════════════════════════════════════\n// UNLOCK CODE\n// ═══════════════════════════════════════════════════════════\n\nconst UNLOCK_CODE = Deno.env.get(\"UNLOCK_CODE\") || \"5428\";\nconst MAX_UNLOCK_ATTEMPTS = 3;\nconst MAX_UNLOCK_MESSAGE_LENGTH = 20;\nconst REDACT_MARKER = \"[חסום]\";\n\n// ═══════════════════════════════════════════════════════════\n// SECURITY\n// ═══════════════════════════════════════════════════════════\n\nconst CANARY_TOKEN = \"CANARY-XYZ789-ALPHA-UNIQUE\";\nconst SYSTEM_PROMPT_OVERLAP_THRESHOLD = 0.4;\n\n// ═══════════════════════════════════════════════════════════\n// CLEANUP\n// ═══════════════════════════════════════════════════════════\n\nconst CLEANUP_OLDER_THAN = \"-1 day\";\nconst CLEANUP_PROBABILITY = 0.05;\n\n// ═══════════════════════════════════════════════════════════\n// CENSORSHIP WORDLIST\n// ═══════════════════════════════════════════════════════════\n\nconst FORBIDDEN_WORDS = [\n \"דת\", \"אלוהים\", \"יהוה\", \"אללה\", \"ישו\",\n \"פוליטיקה\", \"ממשלה\", \"בחירות\", \"כנסת\", \"ראש ממשלה\",\n \"מין\", \"סקס\", \"פורנוגרפיה\", \"אונס\",\n \"הפלה\", \"המתת חסד\", \"סמים\", \"אלכוהול\", \"הימורים\",\n \"התאבדות\", \"טרור\",\n];\n\n// ═══════════════════════════════════════════════════════════\n// REFUSAL DETECTION PATTERNS\n// ═══════════════════════════════════════════════════════════\n\nconst REFUSAL_PHRASES = [\n \"אין לי גישה\",\n \"אין לי אפשרות לגשת\",\n \"לא מחובר לאינטרנט\",\n \"אני לא יכול לגשת\",\n \"אין לי חיבור\",\n \"לא מעודכן\",\n \"הידע שלי מוגבל\",\n \"הידע שלי הוא עד\",\n \"אני לא יכול לבדוק\",\n \"אני לא יכול לחפש\",\n \"אין באפשרותי\",\n \"לא יכול לעזור בנושא\",\n];\n\n// ═══════════════════════════════════════════════════════════\n// HTTP LAYER - Fetch with timeout and retry\n// ═══════════════════════════════════════════════════════════\n\nasync function fetchWithTimeout(\n url: string,\n init: RequestInit,\n timeoutMs: number = TIMEOUT_MS,\n): Promise {\n const controller = new AbortController();\n const timer = setTimeout(() => controller.abort(), timeoutMs);\n try {\n return await fetch(url, { ...init, signal: controller.signal });\n } finally {\n clearTimeout(timer);\n }\n}\n\nasync function fetchWithRetry(\n url: string,\n init: RequestInit,\n timeoutMs: number = TIMEOUT_MS,\n): Promise {\n let lastResp: Response | null = null;\n let lastError: Error | null = null;\n\n for (let attempt = 1; attempt <= MAX_RETRIES; attempt++) {\n try {\n const resp = await fetchWithTimeout(url, init, timeoutMs);\n if (resp.status !== 429 && resp.status !== 503 && resp.status !== 504) {\n return resp;\n }\n lastResp = resp;\n const retryAfter = resp.headers.get(\"retry-after\");\n let delayMs = retryAfter\n ? parseInt(retryAfter, 10) * 1000\n : Math.min(\n INITIAL_RETRY_DELAY_MS * Math.pow(2, attempt - 1),\n MAX_RETRY_DELAY_MS,\n );\n delayMs += Math.random() * 200;\n if (attempt < MAX_RETRIES) {\n console.log(`[RETRY] HTTP ${resp.status} - ${attempt}/${MAX_RETRIES} in ${Math.round(delayMs)}ms`);\n await new Promise((resolve) => setTimeout(resolve, delayMs));\n }\n } catch (error) {\n lastError = error as Error;\n console.log(`[RETRY] Error ${attempt}: ${lastError.message}`);\n if (attempt < MAX_RETRIES) {\n await new Promise((resolve) =>\n setTimeout(resolve, INITIAL_RETRY_DELAY_MS * attempt)\n );\n }\n }\n }\n\n if (lastResp) return lastResp;\n throw lastError ?? new Error(`All ${MAX_RETRIES} retries failed for ${url}`);\n}\n\n// ═══════════════════════════════════════════════════════════\n// SEARCH DETECTION\n// ═══════════════════════════════════════════════════════════\n\nfunction needsSearch(query: string): { need: boolean; reason: string } {\n const explicitCommands = [\n \"תעשה חיפוש\", \"תחפש\", \"תחפז\", \"תחפס\",\n \"חפש\", \"חפז\", \"חפס\",\n \"תבדוק באינטרנט\", \"בדוק באינטרנט\",\n ];\n if (explicitCommands.some((cmd) => query.includes(cmd))) {\n return { need: true, reason: \"forced\" };\n }\n\n const autoKeywords = [\n \"היום\", \"עכשיו\", \"כרגע\", \"אחרון\", \"אחרונות\", \"חדשות\",\n \"מזג\", \"שער\", \"מחיר\", \"מתי\", \"2025\", \"2026\",\n \"מי\", \"מה קרה\", \"איפה\", \"כמה\", \"השווה\", \"למה\", \"איך\",\n \"מניות\", \"בורסה\", \"דולר\", \"יורו\", \"ביטקוין\",\n \"נשיא\", \"ראש ממשלה\", \"מלחמה\", \"מזג האוויר\",\n ];\n if (autoKeywords.some((keyword) => query.includes(keyword))) {\n return { need: true, reason: \"auto\" };\n }\n\n return { need: false, reason: \"no\" };\n}\n\nfunction cleanQuery(query: string): string {\n let cleaned = query;\n const strip = [\n \"תעשה חיפוש\", \"תחפש\", \"תחפז\", \"תחפס\",\n \"חפש\", \"חפז\", \"חפס\",\n \"תבדוק באינטרנט\", \"בדוק באינטרנט\",\n \"על\", \"לי\", \"בבקשה\", \"אפשר\",\n ];\n for (const word of strip) {\n cleaned = cleaned.replace(new RegExp(word, \"g\"), \" \");\n }\n return cleaned.replace(/\\s+/g, \" \").trim();\n}\n\nfunction getTimeRange(query: string): string | undefined {\n if (/היום|עכשיו|כרגע/.test(query)) return \"day\";\n if (/השבוע|אחרון|אחרונות/.test(query)) return \"week\";\n if (/החודש/.test(query)) return \"month\";\n if (/השנה/.test(query)) return \"year\";\n return undefined;\n}\n\nfunction getTopic(query: string): string {\n if (/חדשות|מה קרה/.test(query)) return \"news\";\n if (/מניות|בורסה|שער|דולר|יורו|ביטקוין/.test(query)) return \"finance\";\n return \"general\";\n}\n\n// ═══════════════════════════════════════════════════════════\n// UNLOCK CODE REDACTION\n// ═══════════════════════════════════════════════════════════\n\nfunction redactUnlockCode(text: string): string {\n if (!text) return text;\n const digitPattern = UNLOCK_CODE.split(\"\").join(\"[\\\\s\\\\-_.]*\");\n const regex = new RegExp(digitPattern, \"g\");\n return text.replace(regex, REDACT_MARKER);\n}\n\n// ═══════════════════════════════════════════════════════════\n// TTS CLEANING\n// ═══════════════════════════════════════════════════════════\n\nfunction cleanForTTS(text: string, max = TTS_MAX_CHARS): string {\n if (!text) return \"\";\n\n let cleaned = redactUnlockCode(text);\n\n cleaned = cleaned\n .replace(/[\\u{1F300}-\\u{1FAFF}]/gu, \"\")\n .replace(/[\\u{2600}-\\u{26FF}]/gu, \"\")\n .replace(/[*_`~#>]/g, \"\")\n .replace(/[=&|\"'{}[\\]]/g, \" \")\n .replace(/[\\u2013\\u2014\\u2015]/g, \"-\")\n .replace(/[\\u2022\\u25CF\\u25CB]/g, \"-\")\n .replace(/\\n+/g, \" \")\n .replace(/\\s+/g, \" \")\n .trim();\n\n if (cleaned.length > max) {\n cleaned = cleaned.slice(0, max);\n const lastPeriod = cleaned.lastIndexOf(\".\");\n if (lastPeriod > max * 0.6) {\n cleaned = cleaned.slice(0, lastPeriod + 1);\n }\n }\n\n if (cleaned && !/[.!?]$/.test(cleaned)) {\n cleaned += \".\";\n }\n\n return cleaned;\n}\n\n// ═══════════════════════════════════════════════════════════\n// RESPONSE BUILDERS\n// ═══════════════════════════════════════════════════════════\n\nfunction buildReadResponse(text: string, nextVar: string): string {\n const cleaned = cleanForTTS(text);\n const safeText = cleaned || \"רגע, אני חושב.\";\n\n if (safeText.length <= TTS_SPLIT_THRESHOLD) {\n return `read=t-${safeText}=${nextVar},no,record,/9,,no,yes,no,,15`;\n }\n\n let cut = safeText.lastIndexOf(\".\", TTS_SPLIT_THRESHOLD);\n if (cut < TTS_SPLIT_THRESHOLD * 0.5) {\n cut = safeText.lastIndexOf(\" \", TTS_SPLIT_THRESHOLD);\n }\n if (cut < 100) cut = TTS_SPLIT_THRESHOLD;\n\n const part1 = safeText.slice(0, cut + 1).trim();\n const part2 = safeText.slice(cut + 1).trim();\n\n if (!part2) {\n return `read=t-${part1}=${nextVar},no,record,/9,,no,yes,no,,15`;\n }\n\n return `id_list_message=t-${part1}&read=t-${part2}=${nextVar},no,record,/9,,no,yes,no,,15`;\n}\n\nfunction textResponse(body: string): Response {\n return new Response(body, {\n headers: { \"Content-Type\": \"text/plain; charset=utf-8\" },\n });\n}\n\n// ═══════════════════════════════════════════════════════════\n// CANARY / LEAK DETECTION\n// ═══════════════════════════════════════════════════════════\n\nfunction extractNgrams(text: string, n = 5): Set {\n const words = text\n .toLowerCase()\n .replace(/[^\\w\\u0590-\\u05FF\\s]/g, \"\")\n .split(/\\s+/)\n .filter((word) => word.length > 2);\n const ngrams = new Set();\n for (let i = 0; i <= words.length - n; i++) {\n ngrams.add(words.slice(i, i + n).join(\" \"));\n }\n return ngrams;\n}\n\nfunction overlapRatio(textA: string, textB: string): number {\n const ngramsA = extractNgrams(textA);\n const ngramsB = extractNgrams(textB);\n if (!ngramsA.size || !ngramsB.size) return 0;\n let overlap = 0;\n for (const ngram of ngramsA) {\n if (ngramsB.has(ngram)) overlap++;\n }\n return overlap / Math.min(ngramsA.size, ngramsB.size);\n}\n\nfunction isSystemPromptLeak(answer: string, systemPrompt: string): boolean {\n return answer.includes(CANARY_TOKEN) ||\n overlapRatio(answer, systemPrompt) > SYSTEM_PROMPT_OVERLAP_THRESHOLD;\n}\n\n// ═══════════════════════════════════════════════════════════\n// UNLOCK CODE HANDLING\n// ═══════════════════════════════════════════════════════════\n\nfunction detectUnlockCode(query: string): boolean {\n const trimmed = query.trim();\n if (trimmed.length > MAX_UNLOCK_MESSAGE_LENGTH) return false;\n const cleaned = trimmed.replace(/[^\\d]/g, \"\");\n return cleaned === UNLOCK_CODE && cleaned.length >= 3;\n}\n\nfunction isPureDigitsMessage(query: string): boolean {\n return /^\\s*\\d{3,8}\\s*$/.test(query.trim());\n}\n\n// ═══════════════════════════════════════════════════════════\n// ANONYMOUS CALL ID\n// ═══════════════════════════════════════════════════════════\n\nfunction generateAnonCallId(params: URLSearchParams): string {\n const parts = [\n params.get(\"ApiExtension\"),\n params.get(\"ApiRealCaller\"),\n params.get(\"ApiDID\"),\n params.get(\"ApiPhone\"),\n ].filter(Boolean).join(\"-\");\n\n const timeBucket = Math.floor(Date.now() / 60000);\n const random = Math.random().toString(36).slice(2, 8);\n\n return `anon-${parts || timeBucket}-${random}`;\n}\n\n// ═══════════════════════════════════════════════════════════\n// CENSORSHIP LAYERS\n// ═══════════════════════════════════════════════════════════\n\nfunction isForbiddenKeyword(query: string): boolean {\n const lower = query.toLowerCase();\n return FORBIDDEN_WORDS.some((word) => lower.includes(word));\n}\n\nasync function checkGroqModel(query: string, model: string): Promise {\n const GROQ_API_KEY = Deno.env.get(\"GROQ_API_KEY\");\n if (!GROQ_API_KEY) return \"\";\n try {\n const resp = await fetchWithTimeout(\n \"https://api.groq.com/openai/v1/chat/completions\",\n {\n method: \"POST\",\n headers: {\n Authorization: `Bearer ${GROQ_API_KEY}`,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({\n model,\n messages: [{ role: \"user\", content: query }],\n max_tokens: 32,\n temperature: 0.0,\n }),\n },\n CENSOR_TIMEOUT_MS,\n );\n if (!resp.ok) return \"\";\n const data = await resp.json();\n return (data.choices?.[0]?.message?.content || \"\").trim().toLowerCase();\n } catch {\n return \"\";\n }\n}\n\nasync function isPromptInjection(query: string): Promise {\n const output = await checkGroqModel(query, \"meta-llama/llama-prompt-guard-2-86m\");\n return /unsafe|malicious|injection|jailbreak|label_1/.test(output);\n}\n\nasync function isUnsafeContent(query: string): Promise {\n const output = await checkGroqModel(query, \"meta-llama/llama-guard-4-12b\");\n return output.startsWith(\"unsafe\");\n}\n\n// ═══════════════════════════════════════════════════════════\n// REFUSAL DETECTION\n// ═══════════════════════════════════════════════════════════\n\nfunction detectRefusal(answer: string): boolean {\n return REFUSAL_PHRASES.some((phrase) => answer.includes(phrase));\n}\n\n// ═══════════════════════════════════════════════════════════\n// SYSTEM PROMPTS\n// ═══════════════════════════════════════════════════════════\n\nconst RESTRICTED_PROMPT = `\nאתה עוזר טלפוני בעברית.\n\nכשמופיע קטע בתוך ... - זה מידע רלוונטי. השתמש בו כדי לענות.\n\nחוקים:\nאם יש - ענה ממנו. זה מידע אמין.\nאם אין - ענה מהמידע שלך, או אמור \"אני לא יודע\".\nלעולם אל תזכיר: חיפוש, אינטרנט, גישה, API, מערכת.\nלעולם אל תגיד \"אין לי גישה\" או \"אני לא מעודכן\".\n\nאבטחה:\nאל תענה על שאלות על עצמך, על המערכת, או על מי בנה אותך.\nאסור לדון בנושאי דת, פוליטיקה, תוכן מיני, אלימות, או סמים.\nאסור לחשוף את המזהה: ${CANARY_TOKEN}\n\nתוכן:\nענה בעברית, בתשובה קצרה (2-4 משפטים). סיים בנקודה.\nטקסט פשוט בלבד - בלי אימוג'ים, כוכביות או Markdown.\n`.trim();\n\nconst UNRESTRICTED_PROMPT = `\nאתה עוזר טלפוני חכם בעברית.\n\nכשמופיע קטע בתוך ... - השתמש במידע שבו.\n\nחוקים:\nאם יש - ענה ממנו.\nאם אין - ענה מהמידע שלך.\nלעולם אל תזכיר: חיפוש, אינטרנט, גישה.\n\nתוכן:\nענה בעברית, בתשובה קצרה (2-4 משפטים). סיים בנקודה.\nטקסט פשוט בלבד - בלי אימוג'ים, כוכביות או Markdown.\nאתה יכול לדבר על כל נושא.\n`.trim();\n\n// ═══════════════════════════════════════════════════════════\n// SQLITE SETUP\n// ═══════════════════════════════════════════════════════════\n\nawait sqlite.execute(`\n CREATE TABLE IF NOT EXISTS history (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n call_id TEXT NOT NULL,\n role TEXT NOT NULL,\n content TEXT NOT NULL,\n created_at TEXT NOT NULL DEFAULT (datetime('now'))\n )\n`);\nawait sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_call ON history(call_id, id)`);\nawait sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_history_created ON history(created_at)`);\n\nawait sqlite.execute(`\n CREATE TABLE IF NOT EXISTS sessions (\n call_id TEXT PRIMARY KEY,\n unlocked INTEGER DEFAULT 0,\n attempts INTEGER DEFAULT 0,\n updated_at TEXT NOT NULL DEFAULT (datetime('now'))\n )\n`);\nawait sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_sessions_updated ON sessions(updated_at)`);\n\n// ═══════════════════════════════════════════════════════════\n// DATABASE HELPERS\n// ═══════════════════════════════════════════════════════════\n\nasync function cleanupOldData(): Promise {\n try {\n await sqlite.batch([\n {\n sql: `DELETE FROM sessions WHERE updated_at < datetime('now', ?)`,\n args: [CLEANUP_OLDER_THAN],\n },\n {\n sql: `DELETE FROM history WHERE created_at < datetime('now', ?)`,\n args: [CLEANUP_OLDER_THAN],\n },\n ]);\n } catch (error) {\n console.log(`[CLEANUP] Failed: ${(error as Error).message}`);\n }\n}\n\nasync function getSession(\n callId: string,\n): Promise<{ unlocked: boolean; attempts: number }> {\n await sqlite.execute({\n sql: `INSERT OR IGNORE INTO sessions (call_id, unlocked, attempts) VALUES (?, 0, 0)`,\n args: [callId],\n });\n const result = await sqlite.execute({\n sql: `SELECT unlocked, attempts FROM sessions WHERE call_id = ?`,\n args: [callId],\n });\n const row = result.rows[0] as any;\n return row\n ? { unlocked: row.unlocked === 1, attempts: row.attempts }\n : { unlocked: false, attempts: 0 };\n}\n\nasync function updateSession(\n callId: string,\n unlocked: boolean,\n attempts: number,\n): Promise {\n await sqlite.execute({\n sql: `INSERT INTO sessions (call_id, unlocked, attempts, updated_at)\n VALUES (?, ?, ?, datetime('now'))\n ON CONFLICT(call_id) DO UPDATE SET\n unlocked = ?,\n attempts = ?,\n updated_at = datetime('now')`,\n args: [callId, unlocked ? 1 : 0, attempts, unlocked ? 1 : 0, attempts],\n });\n}\n\nasync function getHistory(\n callId: string,\n): Promise<{ role: string; content: string }[]> {\n const result = await sqlite.execute({\n sql: `SELECT role, content FROM history WHERE call_id = ? ORDER BY id DESC LIMIT 6`,\n args: [callId],\n });\n return (result.rows as unknown as { role: string; content: string }[]).reverse();\n}\n\nasync function saveExchange(\n callId: string,\n userMsg: string,\n assistantMsg: string,\n): Promise {\n await sqlite.batch([\n {\n sql: `INSERT INTO history (call_id, role, content) VALUES (?, 'user', ?)`,\n args: [callId, userMsg],\n },\n {\n sql: `INSERT INTO history (call_id, role, content) VALUES (?, 'assistant', ?)`,\n args: [callId, assistantMsg],\n },\n {\n sql: `DELETE FROM history WHERE call_id = ? AND id NOT IN (\n SELECT id FROM history WHERE call_id = ? ORDER BY id DESC LIMIT 20\n )`,\n args: [callId, callId],\n },\n ]);\n}\n\nasync function clearSession(callId: string): Promise {\n await sqlite.batch([\n { sql: `DELETE FROM history WHERE call_id = ?`, args: [callId] },\n { sql: `DELETE FROM sessions WHERE call_id = ?`, args: [callId] },\n ]);\n}\n\n// ═══════════════════════════════════════════════════════════\n// YEMOT FILE DOWNLOAD\n// ═══════════════════════════════════════════════════════════\n\nasync function downloadRecording(recordingPath: string): Promise {\n const token = Deno.env.get(\"YEMOT_TOKEN\");\n if (!token) throw new Error(\"YEMOT_TOKEN not set\");\n\n let path = recordingPath;\n if (!path.startsWith(\"ivr2:\")) {\n path = \"ivr2:\" + (path.startsWith(\"/\") ? path : \"/\" + path);\n }\n\n const base = Deno.env.get(\"YEMOT_BASE\") || \"https://www.call2all.co.il/ym/api\";\n const url = `${base}/DownloadFile?token=${encodeURIComponent(token)}&path=${encodeURIComponent(path)}`;\n\n const res = await fetchWithTimeout(url, {});\n if (!res.ok) throw new Error(`DownloadFile HTTP ${res.status}`);\n\n return new Uint8Array(await res.arrayBuffer());\n}\n\n// ═══════════════════════════════════════════════════════════\n// WHISPER TRANSCRIPTION\n// ═══════════════════════════════════════════════════════════\n\nasync function transcribe(audio: Uint8Array): Promise {\n const GROQ_API_KEY = Deno.env.get(\"GROQ_API_KEY\")!;\n\n const form = new FormData();\n form.append(\"file\", new Blob([audio], { type: \"audio/wav\" }), \"rec.wav\");\n form.append(\"model\", \"whisper-large-v3-turbo\");\n form.append(\"language\", \"he\");\n form.append(\"response_format\", \"json\");\n form.append(\"prompt\", \"שיחה טלפונית בעברית, שאלות ותשובות יומיומיות\");\n form.append(\"temperature\", \"0\");\n\n const res = await fetchWithTimeout(\n \"https://api.groq.com/openai/v1/audio/transcriptions\",\n {\n method: \"POST\",\n headers: { Authorization: `Bearer ${GROQ_API_KEY}` },\n body: form,\n },\n );\n\n if (!res.ok) throw new Error(`Whisper HTTP ${res.status}`);\n\n const data = await res.json();\n return (data.text || \"\").trim();\n}\n\n// ═══════════════════════════════════════════════════════════\n// GROQ LLM\n// ═══════════════════════════════════════════════════════════\n\nasync function askLLMCore(\n messages: { role: string; content: string }[],\n systemPrompt: string,\n model: string,\n): Promise {\n const GROQ_API_KEY = Deno.env.get(\"GROQ_API_KEY\")!;\n\n const body: Record = {\n model,\n messages,\n max_completion_tokens: MAX_COMPLETION_TOKENS,\n temperature: 0.7,\n top_p: 0.80,\n };\n\n if (model.startsWith(\"qwen/\")) {\n body.reasoning_effort = \"none\";\n body.reasoning_format = \"hidden\";\n } else {\n body.reasoning_effort = \"low\";\n body.include_reasoning = false;\n body.temperature = 0.4;\n }\n\n const res = await fetchWithRetry(\n \"https://api.groq.com/openai/v1/chat/completions\",\n {\n method: \"POST\",\n headers: {\n Authorization: `Bearer ${GROQ_API_KEY}`,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify(body),\n },\n LLM_TIMEOUT_MS,\n );\n\n if (!res.ok) throw new Error(`LLM HTTP ${res.status}`);\n\n const data = await res.json();\n let answer = (data.choices?.[0]?.message?.content || \"\").trim();\n\n if (isSystemPromptLeak(answer, systemPrompt)) {\n console.log(\"[SECURITY] System prompt leak detected - blocked\");\n answer = \"אני לא יכול לענות על זה. אפשר לשאול משהו אחר?\";\n }\n\n return answer;\n}\n\nasync function askLLM(\n messages: { role: string; content: string }[],\n systemPrompt: string,\n): Promise {\n try {\n return await askLLMCore(messages, systemPrompt, \"qwen/qwen3.6-27b\");\n } catch (error) {\n console.log(`[LLM] Qwen failed (${(error as Error).message}), falling back to gpt-oss-120b`);\n return await askLLMCore(messages, systemPrompt, \"openai/gpt-oss-120b\");\n }\n}\n\n// ═══════════════════════════════════════════════════════════\n// TAVILY SEARCH\n// ═══════════════════════════════════════════════════════════\n\nasync function searchTavily(query: string): Promise {\n const TAVILY_API_KEY = Deno.env.get(\"TAVILY_API_KEY\");\n if (!TAVILY_API_KEY) return \"\";\n\n const body: Record = {\n query: cleanQuery(query),\n search_depth: \"basic\",\n max_results: TAVILY_RESULTS,\n include_answer: false,\n };\n\n const timeRange = getTimeRange(query);\n if (timeRange) body.time_range = timeRange;\n\n const topic = getTopic(query);\n if (topic !== \"general\") body.topic = topic;\n\n const startTime = Date.now();\n try {\n const resp = await fetchWithTimeout(\n \"https://api.tavily.com/search\",\n {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n Authorization: `Bearer ${TAVILY_API_KEY}`,\n },\n body: JSON.stringify(body),\n },\n SEARCH_TIMEOUT_MS,\n );\n\n const elapsed = Date.now() - startTime;\n console.log(`[TAVILY] ${elapsed}ms, status=${resp.status}`);\n\n if (!resp.ok) {\n console.log(`[TAVILY] Failed: HTTP ${resp.status}`);\n return \"\";\n }\n\n const data = await resp.json();\n const results = (Array.isArray(data.results) ? data.results : [])\n .map((r: any) => (r.content ?? \"\").slice(0, TAVILY_CONTENT_MAX))\n .filter(Boolean)\n .join(\" \");\n\n console.log(`[TAVILY] Got ${results.length} chars from ${(data.results || []).length} results`);\n return results;\n } catch (error) {\n console.log(`[TAVILY] Exception (${Date.now() - startTime}ms): ${(error as Error).message}`);\n return \"\";\n }\n}\n\n// ═══════════════════════════════════════════════════════════\n// RECORDING EXTRACTION\n// ═══════════════════════════════════════════════════════════\n\nfunction extractLatestRecording(params: URLSearchParams): string {\n let latest = \"\";\n for (let i = 1; i < 100; i++) {\n const value = params.get(`rec${i}`);\n if (value) latest = value;\n }\n return latest || params.get(\"RECORD_PATH\") || \"\";\n}\n\nfunction countRecordings(params: URLSearchParams): number {\n let count = 0;\n for (let i = 1; i < 100; i++) {\n if (params.get(`rec${i}`)) count = i;\n }\n return count;\n}\n\n// ═══════════════════════════════════════════════════════════\n// MAIN HANDLER\n// ═══════════════════════════════════════════════════════════\n\nexport default async function handler(req: Request): Promise {\n const requestStart = Date.now();\n\n try {\n // Health check\n if (req.method === \"GET\") {\n return textResponse(\"YEMOT BOT v5.1 LIVE\");\n }\n\n if (req.method !== \"POST\") {\n return textResponse(buildReadResponse(\"נשלחו נתונים בפורמט לא תקין\", \"rec1\"));\n }\n\n // Parse parameters\n const form = await req.formData();\n const params = new URLSearchParams();\n for (const [key, value] of form.entries()) {\n if (typeof value === \"string\") params.set(key, value);\n }\n\n // Authentication\n const expected = Deno.env.get(\"YEMOT_SECRET\");\n if (expected && params.get(\"secret\") !== expected) {\n return new Response(\"forbidden\", { status: 403 });\n }\n\n // Handle hangup\n const hangup = params.get(\"hangup\");\n if (hangup && hangup !== \"no\" && hangup !== \"0\") {\n const callId = params.get(\"ApiCallId\") || params.get(\"ApiPhone\") || \"\";\n if (callId) await clearSession(callId);\n return textResponse(\"\");\n }\n\n // Opportunistic cleanup\n if (Math.random() < CLEANUP_PROBABILITY) {\n await cleanupOldData();\n }\n\n // Constants\n const GREETING = \"שלום, הגעתם לבינה מלאכותית של מוטי כץ, מה תרצו לשאול\";\n const NOT_HEARD = \"לא שמעתי אותך, אנא נסה שוב\";\n const WRONG_CODE = \"קוד שגוי\";\n const REFUSAL_FALLBACK = \"מצטער, יש לי בעיה טכנית כרגע. נסה שוב בעוד רגע\";\n\n // Extract call data\n const latestRecording = extractLatestRecording(params);\n const nextVar = `rec${countRecordings(params) + 1}`;\n const callId = params.get(\"ApiCallId\") ||\n params.get(\"ApiPhone\") ||\n generateAnonCallId(params);\n\n console.log(`[CALL] id=${callId}, rec=${latestRecording || \"none\"}, next=${nextVar}`);\n\n // First request - play greeting\n if (!latestRecording) {\n return textResponse(buildReadResponse(GREETING, nextVar));\n }\n\n // Download recording\n const downloadStart = Date.now();\n const audio = await downloadRecording(latestRecording);\n console.log(`[TIME] Download: ${Date.now() - downloadStart}ms`);\n\n // Transcribe\n const whisperStart = Date.now();\n const userText = await transcribe(audio);\n console.log(`[TIME] Whisper: ${Date.now() - whisperStart}ms | \"${userText}\"`);\n\n if (!userText || userText.length < 2) {\n return textResponse(buildReadResponse(NOT_HEARD, nextVar));\n }\n\n // Get session state\n const session = await getSession(callId);\n\n // ─── UNLOCK CODE HANDLING ──────────────────────────────\n if (!session.unlocked) {\n if (detectUnlockCode(userText)) {\n await updateSession(callId, true, session.attempts);\n await saveExchange(callId, \"[code entered]\", \"[unlocked]\");\n console.log(`[UNLOCK] Call ${callId} unlocked`);\n return textResponse(buildReadResponse(\"מצב חופשי פעיל\", nextVar));\n }\n\n if (session.attempts < MAX_UNLOCK_ATTEMPTS && isPureDigitsMessage(userText)) {\n const newAttempts = session.attempts + 1;\n await updateSession(callId, false, newAttempts);\n console.log(`[UNLOCK] Wrong code attempt ${newAttempts}/${MAX_UNLOCK_ATTEMPTS}`);\n\n if (newAttempts >= MAX_UNLOCK_ATTEMPTS) {\n await clearSession(callId);\n return textResponse(\n \"id_list_message=t-יותר מדי ניסיונות. השיחה מנותקת.&go_to_folder=hangup\",\n );\n }\n\n return textResponse(buildReadResponse(WRONG_CODE, nextVar));\n }\n }\n\n // ─── CENSORSHIP (locked only, skipped when search triggers) ──\n const detection = needsSearch(userText);\n\n if (!session.unlocked && !detection.need) {\n // Layer 1: Forbidden keywords\n if (isForbiddenKeyword(userText)) {\n await saveExchange(callId, userText, \"[blocked:keyword]\");\n console.log(`[CENSOR] Blocked by keyword`);\n return textResponse(buildReadResponse(\n \"אני לא יכול לדבר על זה. אפשר לשאול משהו אחר?\",\n nextVar,\n ));\n }\n\n // Layer 2: Prompt injection\n if (await isPromptInjection(userText)) {\n await saveExchange(callId, userText, \"[blocked:injection]\");\n console.log(`[CENSOR] Blocked by injection detector`);\n return textResponse(buildReadResponse(\"אני לא יכול לענות על זה\", nextVar));\n }\n\n // Layer 3: Unsafe content\n if (await isUnsafeContent(userText)) {\n await saveExchange(callId, userText, \"[blocked:unsafe]\");\n console.log(`[CENSOR] Blocked by safety classifier`);\n return textResponse(buildReadResponse(\"אני לא יכול לענות על זה\", nextVar));\n }\n }\n\n // ─── BUILD MESSAGES ────────────────────────────────────\n const history = await getHistory(callId);\n const systemPrompt = session.unlocked ? UNRESTRICTED_PROMPT : RESTRICTED_PROMPT;\n\n const messages: { role: string; content: string }[] = [\n { role: \"system\", content: systemPrompt },\n ...history,\n ];\n\n // ─── SEARCH ────────────────────────────────────────────\n const detection = needsSearch(userText);\n let finalUserMessage = userText;\n let searchContext = \"\";\n\n if (detection.need) {\n console.log(`[SEARCH] Triggered: ${detection.reason}`);\n searchContext = await searchTavily(userText);\n\n if (searchContext) {\n finalUserMessage = `${userText}\\n\\n\\n${searchContext}\\n`;\n } else {\n console.log(`[SEARCH] No context returned`);\n }\n }\n\n messages.push({ role: \"user\", content: finalUserMessage });\n\n // ─── ASK LLM ───────────────────────────────────────────\n const llmStart = Date.now();\n let answer = await askLLM(messages, systemPrompt);\n console.log(`[TIME] LLM: ${Date.now() - llmStart}ms`);\n\n // Refusal fallback: if LLM refused but we have search context\n if (detectRefusal(answer) && searchContext) {\n console.log(`[REFUSAL] LLM refused - retrying with direct context`);\n\n const directMessages = [\n { role: \"system\", content: systemPrompt },\n ...history,\n {\n role: \"user\",\n content: `${userText}\\n\\nמידע רלוונטי:\\n${searchContext}`,\n },\n ];\n\n answer = await askLLM(directMessages, systemPrompt);\n\n if (detectRefusal(answer)) {\n console.log(`[REFUSAL] Still refused - using fallback`);\n answer = REFUSAL_FALLBACK;\n }\n }\n\n // ─── SAVE + RESPOND ────────────────────────────────────\n await saveExchange(callId, userText, answer);\n\n console.log(`[TIME] TOTAL: ${Date.now() - requestStart}ms`);\n console.log(`[ANSWER] \"${answer.slice(0, 150)}\"`);\n\n return textResponse(buildReadResponse(answer, nextVar));\n\n } catch (error) {\n console.error(`[FATAL] After ${Date.now() - requestStart}ms:`, error);\n return textResponse(buildReadResponse(\"אירעה שגיאה, אנא נסה שוב\", \"rec1\"));\n }\n}\n","\n// ============================================================\n// Yemot Phone Bot v5.1 - Ultimate Production Edition\n// ============================================================\n// Complete Feature Set:\n// • Hebrew AI phone bot with Groq GPT-OSS-120B\n// • Whisper Hebrew transcription\n// • Tavily search (auto + forced)\n// • Unlock code system with silent redaction\n// • 3-layer censorship + Canary token\n// • Response splitting for long answers\n// • Refusal detection + retry logic\n// • Optimized timeouts for Yemot limits\n// ============================================================\n\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\n// ═══════════════════════════════════════════════════════════\n// CONFIGURATION\n// ═══════════════════════════════════════════════════════════\n\nconst TIMEOUT_MS = 3500;\nconst SEARCH_TIMEOUT_MS = 1500;\nconst LLM_TIMEOUT_MS = 3500;\nconst CENSOR_TIMEOUT_MS = 1500;\n\nconst MAX_COMPLETION_TOKENS = 500;\nconst TAVILY_RESULTS = 2;\nconst TAVILY_CONTENT_MAX = 200;\n\nconst TTS_MAX_CHARS = 900;\nconst TTS_SPLIT_THRESHOLD = 1050;\n\nconst MAX_RETRIES = 2;\nconst INITIAL_RETRY_DELAY_MS = 500;\nconst MAX_RETRY_DELAY_MS = 2500;\n\n// ═══════════════════════════════════════════════════════════\n// UNLOCK CODE\n// ═══════════════════════════════════════════════════════════\n\nconst UNLOCK_CODE = Deno.env.get(\"UNLOCK_CODE\") || \"5428\";\nconst MAX_UNLOCK_ATTEMPTS = 3;\nconst MAX_UNLOCK_MESSAGE_LENGTH = 20;\nconst REDACT_MARKER = \"[חסום]\";\n\n// ═══════════════════════════════════════════════════════════\n// SECURITY\n// ═══════════════════════════════════════════════════════════\n\nconst CANARY_TOKEN = \"CANARY-XYZ789-ALPHA-UNIQUE\";\nconst SYSTEM_PROMPT_OVERLAP_THRESHOLD = 0.4;\n\n// ═══════════════════════════════════════════════════════════\n// CLEANUP\n// ═══════════════════════════════════════════════════════════\n\nconst CLEANUP_OLDER_THAN = \"-1 day\";\nconst CLEANUP_PROBABILITY = 0.05;\n\n// ═══════════════════════════════════════════════════════════\n// CENSORSHIP WORDLIST\n// ═══════════════════════════════════════════════════════════\n\nconst FORBIDDEN_WORDS = [\n \"דת\", \"אלוהים\", \"יהוה\", \"אללה\", \"ישו\",\n \"פוליטיקה\", \"ממשלה\", \"בחירות\", \"כנסת\", \"ראש ממשלה\",\n \"מין\", \"סקס\", \"פורנוגרפיה\", \"אונס\",\n \"הפלה\", \"המתת חסד\", \"סמים\", \"אלכוהול\", \"הימורים\",\n \"התאבדות\", \"טרור\",\n];\n\n// ═══════════════════════════════════════════════════════════\n// REFUSAL DETECTION PATTERNS\n// ═══════════════════════════════════════════════════════════\n\nconst REFUSAL_PHRASES = [\n \"אין לי גישה\",\n \"אין לי אפשרות לגשת\",\n \"לא מחובר לאינטרנט\",\n \"אני לא יכול לגשת\",\n \"אין לי חיבור\",\n \"לא מעודכן\",\n \"הידע שלי מוגבל\",\n \"הידע שלי הוא עד\",\n \"אני לא יכול לבדוק\",\n \"אני לא יכול לחפש\",\n \"אין באפשרותי\",\n \"לא יכול לעזור בנושא\",\n];\n\n// ═══════════════════════════════════════════════════════════\n// HTTP LAYER - Fetch with timeout and retry\n// ═══════════════════════════════════════════════════════════\n\nasync function fetchWithTimeout(\n url: string,\n init: RequestInit,\n timeoutMs: number = TIMEOUT_MS,\n): Promise {\n const controller = new AbortController();\n const timer = setTimeout(() => controller.abort(), timeoutMs);\n try {\n return await fetch(url, { ...init, signal: controller.signal });\n } finally {\n clearTimeout(timer);\n }\n}\n\nasync function fetchWithRetry(\n url: string,\n init: RequestInit,\n timeoutMs: number = TIMEOUT_MS,\n): Promise {\n let lastResp: Response | null = null;\n let lastError: Error | null = null;\n\n for (let attempt = 1; attempt <= MAX_RETRIES; attempt++) {\n try {\n const resp = await fetchWithTimeout(url, init, timeoutMs);\n if (resp.status !== 429 && resp.status !== 503 && resp.status !== 504) {\n return resp;\n }\n lastResp = resp;\n const retryAfter = resp.headers.get(\"retry-after\");\n let delayMs = retryAfter\n ? parseInt(retryAfter, 10) * 1000\n : Math.min(\n INITIAL_RETRY_DELAY_MS * Math.pow(2, attempt - 1),\n MAX_RETRY_DELAY_MS,\n );\n delayMs += Math.random() * 200;\n if (attempt < MAX_RETRIES) {\n console.log(`[RETRY] HTTP ${resp.status} - ${attempt}/${MAX_RETRIES} in ${Math.round(delayMs)}ms`);\n await new Promise((resolve) => setTimeout(resolve, delayMs));\n }\n } catch (error) {\n lastError = error as Error;\n console.log(`[RETRY] Error ${attempt}: ${lastError.message}`);\n if (attempt < MAX_RETRIES) {\n await new Promise((resolve) =>\n setTimeout(resolve, INITIAL_RETRY_DELAY_MS * attempt)\n );\n }\n }\n }\n\n if (lastResp) return lastResp;\n throw lastError ?? new Error(`All ${MAX_RETRIES} retries failed for ${url}`);\n}\n\n// ═══════════════════════════════════════════════════════════\n// SEARCH DETECTION\n// ═══════════════════════════════════════════════════════════\n\nfunction needsSearch(query: string): { need: boolean; reason: string } {\n const explicitCommands = [\n \"תעשה חיפוש\", \"תחפש\", \"תחפז\", \"תחפס\",\n \"חפש\", \"חפז\", \"חפס\",\n \"תבדוק באינטרנט\", \"בדוק באינטרנט\",\n ];\n if (explicitCommands.some((cmd) => query.includes(cmd))) {\n return { need: true, reason: \"forced\" };\n }\n\n const autoKeywords = [\n \"היום\", \"עכשיו\", \"כרגע\", \"אחרון\", \"אחרונות\", \"חדשות\",\n \"מזג\", \"שער\", \"מחיר\", \"מתי\", \"2025\", \"2026\",\n \"מי\", \"מה קרה\", \"איפה\", \"כמה\", \"השווה\", \"למה\", \"איך\",\n \"מניות\", \"בורסה\", \"דולר\", \"יורו\", \"ביטקוין\",\n \"נשיא\", \"ראש ממשלה\", \"מלחמה\", \"מזג האוויר\",\n ];\n if (autoKeywords.some((keyword) => query.includes(keyword))) {\n return { need: true, reason: \"auto\" };\n }\n\n return { need: false, reason: \"no\" };\n}\n\nfunction cleanQuery(query: string): string {\n let cleaned = query;\n const strip = [\n \"תעשה חיפוש\", \"תחפש\", \"תחפז\", \"תחפס\",\n \"חפש\", \"חפז\", \"חפס\",\n \"תבדוק באינטרנט\", \"בדוק באינטרנט\",\n \"על\", \"לי\", \"בבקשה\", \"אפשר\",\n ];\n for (const word of strip) {\n cleaned = cleaned.replace(new RegExp(word, \"g\"), \" \");\n }\n return cleaned.replace(/\\s+/g, \" \").trim();\n}\n\nfunction getTimeRange(query: string): string | undefined {\n if (/היום|עכשיו|כרגע/.test(query)) return \"day\";\n if (/השבוע|אחרון|אחרונות/.test(query)) return \"week\";\n if (/החודש/.test(query)) return \"month\";\n if (/השנה/.test(query)) return \"year\";\n return undefined;\n}\n\nfunction getTopic(query: string): string {\n if (/חדשות|מה קרה/.test(query)) return \"news\";\n if (/מניות|בורסה|שער|דולר|יורו|ביטקוין/.test(query)) return \"finance\";\n return \"general\";\n}\n\n// ═══════════════════════════════════════════════════════════\n// UNLOCK CODE REDACTION\n// ═══════════════════════════════════════════════════════════\n\nfunction redactUnlockCode(text: string): string {\n if (!text) return text;\n const digitPattern = UNLOCK_CODE.split(\"\").join(\"[\\\\s\\\\-_.]*\");\n const regex = new RegExp(digitPattern, \"g\");\n return text.replace(regex, REDACT_MARKER);\n}\n\n// ═══════════════════════════════════════════════════════════\n// TTS CLEANING\n// ═══════════════════════════════════════════════════════════\n\nfunction cleanForTTS(text: string, max = TTS_MAX_CHARS): string {\n if (!text) return \"\";\n\n let cleaned = redactUnlockCode(text);\n\n cleaned = cleaned\n .replace(/[\\u{1F300}-\\u{1FAFF}]/gu, \"\")\n .replace(/[\\u{2600}-\\u{26FF}]/gu, \"\")\n .replace(/[*_`~#>]/g, \"\")\n .replace(/[=&|\"'{}[\\]]/g, \" \")\n .replace(/[\\u2013\\u2014\\u2015]/g, \"-\")\n .replace(/[\\u2022\\u25CF\\u25CB]/g, \"-\")\n .replace(/\\n+/g, \" \")\n .replace(/\\s+/g, \" \")\n .trim();\n\n if (cleaned.length > max) {\n cleaned = cleaned.slice(0, max);\n const lastPeriod = cleaned.lastIndexOf(\".\");\n if (lastPeriod > max * 0.6) {\n cleaned = cleaned.slice(0, lastPeriod + 1);\n }\n }\n\n if (cleaned && !/[.!?]$/.test(cleaned)) {\n cleaned += \".\";\n }\n\n return cleaned;\n}\n\n// ═══════════════════════════════════════════════════════════\n// RESPONSE BUILDERS\n// ═══════════════════════════════════════════════════════════\n\nfunction buildReadResponse(text: string, nextVar: string): string {\n const cleaned = cleanForTTS(text);\n const safeText = cleaned || \"רגע, אני חושב.\";\n\n if (safeText.length <= TTS_SPLIT_THRESHOLD) {\n return `read=t-${safeText}=${nextVar},no,record,/9,,no,yes,no,,15`;\n }\n\n let cut = safeText.lastIndexOf(\".\", TTS_SPLIT_THRESHOLD);\n if (cut < TTS_SPLIT_THRESHOLD * 0.5) {\n cut = safeText.lastIndexOf(\" \", TTS_SPLIT_THRESHOLD);\n }\n if (cut < 100) cut = TTS_SPLIT_THRESHOLD;\n\n const part1 = safeText.slice(0, cut + 1).trim();\n const part2 = safeText.slice(cut + 1).trim();\n\n if (!part2) {\n return `read=t-${part1}=${nextVar},no,record,/9,,no,yes,no,,15`;\n }\n\n return `id_list_message=t-${part1}&read=t-${part2}=${nextVar},no,record,/9,,no,yes,no,,15`;\n}\n\nfunction textResponse(body: string): Response {\n return new Response(body, {\n headers: { \"Content-Type\": \"text/plain; charset=utf-8\" },\n });\n}\n\n// ═══════════════════════════════════════════════════════════\n// CANARY / LEAK DETECTION\n// ═══════════════════════════════════════════════════════════\n\nfunction extractNgrams(text: string, n = 5): Set {\n const words = text\n .toLowerCase()\n .replace(/[^\\w\\u0590-\\u05FF\\s]/g, \"\")\n .split(/\\s+/)\n .filter((word) => word.length > 2);\n const ngrams = new Set();\n for (let i = 0; i <= words.length - n; i++) {\n ngrams.add(words.slice(i, i + n).join(\" \"));\n }\n return ngrams;\n}\n\nfunction overlapRatio(textA: string, textB: string): number {\n const ngramsA = extractNgrams(textA);\n const ngramsB = extractNgrams(textB);\n if (!ngramsA.size || !ngramsB.size) return 0;\n let overlap = 0;\n for (const ngram of ngramsA) {\n if (ngramsB.has(ngram)) overlap++;\n }\n return overlap / Math.min(ngramsA.size, ngramsB.size);\n}\n\nfunction isSystemPromptLeak(answer: string, systemPrompt: string): boolean {\n return answer.includes(CANARY_TOKEN) ||\n overlapRatio(answer, systemPrompt) > SYSTEM_PROMPT_OVERLAP_THRESHOLD;\n}\n\n// ═══════════════════════════════════════════════════════════\n// UNLOCK CODE HANDLING\n// ═══════════════════════════════════════════════════════════\n\nfunction detectUnlockCode(query: string): boolean {\n const trimmed = query.trim();\n if (trimmed.length > MAX_UNLOCK_MESSAGE_LENGTH) return false;\n const cleaned = trimmed.replace(/[^\\d]/g, \"\");\n return cleaned === UNLOCK_CODE && cleaned.length >= 3;\n}\n\nfunction isPureDigitsMessage(query: string): boolean {\n return /^\\s*\\d{3,8}\\s*$/.test(query.trim());\n}\n\n// ═══════════════════════════════════════════════════════════\n// ANONYMOUS CALL ID\n// ═══════════════════════════════════════════════════════════\n\nfunction generateAnonCallId(params: URLSearchParams): string {\n const parts = [\n params.get(\"ApiExtension\"),\n params.get(\"ApiRealCaller\"),\n params.get(\"ApiDID\"),\n params.get(\"ApiPhone\"),\n ].filter(Boolean).join(\"-\");\n\n const timeBucket = Math.floor(Date.now() / 60000);\n const random = Math.random().toString(36).slice(2, 8);\n\n return `anon-${parts || timeBucket}-${random}`;\n}\n\n// ═══════════════════════════════════════════════════════════\n// CENSORSHIP LAYERS\n// ═══════════════════════════════════════════════════════════\n\nfunction isForbiddenKeyword(query: string): boolean {\n const lower = query.toLowerCase();\n return FORBIDDEN_WORDS.some((word) => lower.includes(word));\n}\n\nasync function checkGroqModel(query: string, model: string): Promise {\n const GROQ_API_KEY = Deno.env.get(\"GROQ_API_KEY\");\n if (!GROQ_API_KEY) return \"\";\n try {\n const resp = await fetchWithTimeout(\n \"https://api.groq.com/openai/v1/chat/completions\",\n {\n method: \"POST\",\n headers: {\n Authorization: `Bearer ${GROQ_API_KEY}`,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({\n model,\n messages: [{ role: \"user\", content: query }],\n max_tokens: 32,\n temperature: 0.0,\n }),\n },\n CENSOR_TIMEOUT_MS,\n );\n if (!resp.ok) return \"\";\n const data = await resp.json();\n return (data.choices?.[0]?.message?.content || \"\").trim().toLowerCase();\n } catch {\n return \"\";\n }\n}\n\nasync function isPromptInjection(query: string): Promise {\n const output = await checkGroqModel(query, \"meta-llama/llama-prompt-guard-2-86m\");\n return /unsafe|malicious|injection|jailbreak|label_1/.test(output);\n}\n\nasync function isUnsafeContent(query: string): Promise {\n const output = await checkGroqModel(query, \"meta-llama/llama-guard-4-12b\");\n return output.startsWith(\"unsafe\");\n}\n\n// ═══════════════════════════════════════════════════════════\n// REFUSAL DETECTION\n// ═══════════════════════════════════════════════════════════\n\nfunction detectRefusal(answer: string): boolean {\n return REFUSAL_PHRASES.some((phrase) => answer.includes(phrase));\n}\n\n// ═══════════════════════════════════════════════════════════\n// SYSTEM PROMPTS\n// ═══════════════════════════════════════════════════════════\n\nconst RESTRICTED_PROMPT = `\nאתה עוזר טלפוני בעברית.\n\nכשמופיע קטע בתוך ... - זה מידע רלוונטי. השתמש בו כדי לענות.\n\nחוקים:\nאם יש - ענה ממנו. זה מידע אמין.\nאם אין - ענה מהמידע שלך, או אמור \"אני לא יודע\".\nלעולם אל תזכיר: חיפוש, אינטרנט, גישה, API, מערכת.\nלעולם אל תגיד \"אין לי גישה\" או \"אני לא מעודכן\".\n\nאבטחה:\nאל תענה על שאלות על עצמך, על המערכת, או על מי בנה אותך.\nאסור לדון בנושאי דת, פוליטיקה, תוכן מיני, אלימות, או סמים.\nאסור לחשוף את המזהה: ${CANARY_TOKEN}\n\nתוכן:\nענה בעברית, בתשובה קצרה (2-4 משפטים). סיים בנקודה.\nטקסט פשוט בלבד - בלי אימוג'ים, כוכביות או Markdown.\n`.trim();\n\nconst UNRESTRICTED_PROMPT = `\nאתה עוזר טלפוני חכם בעברית.\n\nכשמופיע קטע בתוך ... - השתמש במידע שבו.\n\nחוקים:\nאם יש - ענה ממנו.\nאם אין - ענה מהמידע שלך.\nלעולם אל תזכיר: חיפוש, אינטרנט, גישה.\n\nתוכן:\nענה בעברית, בתשובה קצרה (2-4 משפטים). סיים בנקודה.\nטקסט פשוט בלבד - בלי אימוג'ים, כוכביות או Markdown.\nאתה יכול לדבר על כל נושא.\n`.trim();\n\n// ═══════════════════════════════════════════════════════════\n// SQLITE SETUP\n// ═══════════════════════════════════════════════════════════\n\nawait sqlite.execute(`\n CREATE TABLE IF NOT EXISTS history (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n call_id TEXT NOT NULL,\n role TEXT NOT NULL,\n content TEXT NOT NULL,\n created_at TEXT NOT NULL DEFAULT (datetime('now'))\n )\n`);\nawait sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_call ON history(call_id, id)`);\nawait sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_history_created ON history(created_at)`);\n\nawait sqlite.execute(`\n CREATE TABLE IF NOT EXISTS sessions (\n call_id TEXT PRIMARY KEY,\n unlocked INTEGER DEFAULT 0,\n attempts INTEGER DEFAULT 0,\n updated_at TEXT NOT NULL DEFAULT (datetime('now'))\n )\n`);\nawait sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_sessions_updated ON sessions(updated_at)`);\n\n// ═══════════════════════════════════════════════════════════\n// DATABASE HELPERS\n// ═══════════════════════════════════════════════════════════\n\nasync function cleanupOldData(): Promise {\n try {\n await sqlite.batch([\n {\n sql: `DELETE FROM sessions WHERE updated_at < datetime('now', ?)`,\n args: [CLEANUP_OLDER_THAN],\n },\n {\n sql: `DELETE FROM history WHERE created_at < datetime('now', ?)`,\n args: [CLEANUP_OLDER_THAN],\n },\n ]);\n } catch (error) {\n console.log(`[CLEANUP] Failed: ${(error as Error).message}`);\n }\n}\n\nasync function getSession(\n callId: string,\n): Promise<{ unlocked: boolean; attempts: number }> {\n await sqlite.execute({\n sql: `INSERT OR IGNORE INTO sessions (call_id, unlocked, attempts) VALUES (?, 0, 0)`,\n args: [callId],\n });\n const result = await sqlite.execute({\n sql: `SELECT unlocked, attempts FROM sessions WHERE call_id = ?`,\n args: [callId],\n });\n const row = result.rows[0] as any;\n return row\n ? { unlocked: row.unlocked === 1, attempts: row.attempts }\n : { unlocked: false, attempts: 0 };\n}\n\nasync function updateSession(\n callId: string,\n unlocked: boolean,\n attempts: number,\n): Promise {\n await sqlite.execute({\n sql: `INSERT INTO sessions (call_id, unlocked, attempts, updated_at)\n VALUES (?, ?, ?, datetime('now'))\n ON CONFLICT(call_id) DO UPDATE SET\n unlocked = ?,\n attempts = ?,\n updated_at = datetime('now')`,\n args: [callId, unlocked ? 1 : 0, attempts, unlocked ? 1 : 0, attempts],\n });\n}\n\nasync function getHistory(\n callId: string,\n): Promise<{ role: string; content: string }[]> {\n const result = await sqlite.execute({\n sql: `SELECT role, content FROM history WHERE call_id = ? ORDER BY id DESC LIMIT 6`,\n args: [callId],\n });\n return (result.rows as unknown as { role: string; content: string }[]).reverse();\n}\n\nasync function saveExchange(\n callId: string,\n userMsg: string,\n assistantMsg: string,\n): Promise {\n await sqlite.batch([\n {\n sql: `INSERT INTO history (call_id, role, content) VALUES (?, 'user', ?)`,\n args: [callId, userMsg],\n },\n {\n sql: `INSERT INTO history (call_id, role, content) VALUES (?, 'assistant', ?)`,\n args: [callId, assistantMsg],\n },\n {\n sql: `DELETE FROM history WHERE call_id = ? AND id NOT IN (\n SELECT id FROM history WHERE call_id = ? ORDER BY id DESC LIMIT 20\n )`,\n args: [callId, callId],\n },\n ]);\n}\n\nasync function clearSession(callId: string): Promise {\n await sqlite.batch([\n { sql: `DELETE FROM history WHERE call_id = ?`, args: [callId] },\n { sql: `DELETE FROM sessions WHERE call_id = ?`, args: [callId] },\n ]);\n}\n\n// ═══════════════════════════════════════════════════════════\n// YEMOT FILE DOWNLOAD\n// ═══════════════════════════════════════════════════════════\n\nasync function downloadRecording(recordingPath: string): Promise {\n const token = Deno.env.get(\"YEMOT_TOKEN\");\n if (!token) throw new Error(\"YEMOT_TOKEN not set\");\n\n let path = recordingPath;\n if (!path.startsWith(\"ivr2:\")) {\n path = \"ivr2:\" + (path.startsWith(\"/\") ? path : \"/\" + path);\n }\n\n const base = Deno.env.get(\"YEMOT_BASE\") || \"https://www.call2all.co.il/ym/api\";\n const url = `${base}/DownloadFile?token=${encodeURIComponent(token)}&path=${encodeURIComponent(path)}`;\n\n const res = await fetchWithTimeout(url, {});\n if (!res.ok) throw new Error(`DownloadFile HTTP ${res.status}`);\n\n return new Uint8Array(await res.arrayBuffer());\n}\n\n// ═══════════════════════════════════════════════════════════\n// WHISPER TRANSCRIPTION\n// ═══════════════════════════════════════════════════════════\n\nasync function transcribe(audio: Uint8Array): Promise {\n const GROQ_API_KEY = Deno.env.get(\"GROQ_API_KEY\")!;\n\n const form = new FormData();\n form.append(\"file\", new Blob([audio], { type: \"audio/wav\" }), \"rec.wav\");\n form.append(\"model\", \"whisper-large-v3-turbo\");\n form.append(\"language\", \"he\");\n form.append(\"response_format\", \"json\");\n form.append(\"prompt\", \"שיחה טלפונית בעברית, שאלות ותשובות יומיומיות\");\n form.append(\"temperature\", \"0\");\n\n const res = await fetchWithTimeout(\n \"https://api.groq.com/openai/v1/audio/transcriptions\",\n {\n method: \"POST\",\n headers: { Authorization: `Bearer ${GROQ_API_KEY}` },\n body: form,\n },\n );\n\n if (!res.ok) throw new Error(`Whisper HTTP ${res.status}`);\n\n const data = await res.json();\n return (data.text || \"\").trim();\n}\n\n// ═══════════════════════════════════════════════════════════\n// GROQ LLM\n// ═══════════════════════════════════════════════════════════\n\nasync function askLLMCore(\n messages: { role: string; content: string }[],\n systemPrompt: string,\n model: string,\n): Promise {\n const GROQ_API_KEY = Deno.env.get(\"GROQ_API_KEY\")!;\n\n const body: Record = {\n model,\n messages,\n max_completion_tokens: MAX_COMPLETION_TOKENS,\n temperature: 0.7,\n top_p: 0.80,\n };\n\n if (model.startsWith(\"qwen/\")) {\n body.reasoning_effort = \"none\";\n body.reasoning_format = \"hidden\";\n } else {\n body.reasoning_effort = \"low\";\n body.include_reasoning = false;\n body.temperature = 0.4;\n }\n\n const res = await fetchWithRetry(\n \"https://api.groq.com/openai/v1/chat/completions\",\n {\n method: \"POST\",\n headers: {\n Authorization: `Bearer ${GROQ_API_KEY}`,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify(body),\n },\n LLM_TIMEOUT_MS,\n );\n\n if (!res.ok) throw new Error(`LLM HTTP ${res.status}`);\n\n const data = await res.json();\n let answer = (data.choices?.[0]?.message?.content || \"\").trim();\n\n if (isSystemPromptLeak(answer, systemPrompt)) {\n console.log(\"[SECURITY] System prompt leak detected - blocked\");\n answer = \"אני לא יכול לענות על זה. אפשר לשאול משהו אחר?\";\n }\n\n return answer;\n}\n\nasync function askLLM(\n messages: { role: string; content: string }[],\n systemPrompt: string,\n): Promise {\n try {\n return await askLLMCore(messages, systemPrompt, \"qwen/qwen3.6-27b\");\n } catch (error) {\n console.log(`[LLM] Qwen failed (${(error as Error).message}), falling back to gpt-oss-120b`);\n return await askLLMCore(messages, systemPrompt, \"openai/gpt-oss-120b\");\n }\n}\n\n// ═══════════════════════════════════════════════════════════\n// TAVILY SEARCH\n// ═══════════════════════════════════════════════════════════\n\nasync function searchTavily(query: string): Promise {\n const TAVILY_API_KEY = Deno.env.get(\"TAVILY_API_KEY\");\n if (!TAVILY_API_KEY) return \"\";\n\n const body: Record = {\n query: cleanQuery(query),\n search_depth: \"basic\",\n max_results: TAVILY_RESULTS,\n include_answer: false,\n };\n\n const timeRange = getTimeRange(query);\n if (timeRange) body.time_range = timeRange;\n\n const topic = getTopic(query);\n if (topic !== \"general\") body.topic = topic;\n\n const startTime = Date.now();\n try {\n const resp = await fetchWithTimeout(\n \"https://api.tavily.com/search\",\n {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n Authorization: `Bearer ${TAVILY_API_KEY}`,\n },\n body: JSON.stringify(body),\n },\n SEARCH_TIMEOUT_MS,\n );\n\n const elapsed = Date.now() - startTime;\n console.log(`[TAVILY] ${elapsed}ms, status=${resp.status}`);\n\n if (!resp.ok) {\n console.log(`[TAVILY] Failed: HTTP ${resp.status}`);\n return \"\";\n }\n\n const data = await resp.json();\n const results = (Array.isArray(data.results) ? data.results : [])\n .map((r: any) => (r.content ?? \"\").slice(0, TAVILY_CONTENT_MAX))\n .filter(Boolean)\n .join(\" \");\n\n console.log(`[TAVILY] Got ${results.length} chars from ${(data.results || []).length} results`);\n return results;\n } catch (error) {\n console.log(`[TAVILY] Exception (${Date.now() - startTime}ms): ${(error as Error).message}`);\n return \"\";\n }\n}\n\n// ═══════════════════════════════════════════════════════════\n// RECORDING EXTRACTION\n// ═══════════════════════════════════════════════════════════\n\nfunction extractLatestRecording(params: URLSearchParams): string {\n let latest = \"\";\n for (let i = 1; i < 100; i++) {\n const value = params.get(`rec${i}`);\n if (value) latest = value;\n }\n return latest || params.get(\"RECORD_PATH\") || \"\";\n}\n\nfunction countRecordings(params: URLSearchParams): number {\n let count = 0;\n for (let i = 1; i < 100; i++) {\n if (params.get(`rec${i}`)) count = i;\n }\n return count;\n}\n\n// ═══════════════════════════════════════════════════════════\n// MAIN HANDLER\n// ═══════════════════════════════════════════════════════════\n\nexport default async function handler(req: Request): Promise {\n const requestStart = Date.now();\n\n try {\n // Health check\n if (req.method === \"GET\") {\n return textResponse(\"YEMOT BOT v5.1 LIVE\");\n }\n\n if (req.method !== \"POST\") {\n return textResponse(buildReadResponse(\"נשלחו נתונים בפורמט לא תקין\", \"rec1\"));\n }\n\n // Parse parameters\n const form = await req.formData();\n const params = new URLSearchParams();\n for (const [key, value] of form.entries()) {\n if (typeof value === \"string\") params.set(key, value);\n }\n\n // Authentication\n const expected = Deno.env.get(\"YEMOT_SECRET\");\n if (expected && params.get(\"secret\") !== expected) {\n return new Response(\"forbidden\", { status: 403 });\n }\n\n // Handle hangup\n const hangup = params.get(\"hangup\");\n if (hangup && hangup !== \"no\" && hangup !== \"0\") {\n const callId = params.get(\"ApiCallId\") || params.get(\"ApiPhone\") || \"\";\n if (callId) await clearSession(callId);\n return textResponse(\"\");\n }\n\n // Opportunistic cleanup\n if (Math.random() < CLEANUP_PROBABILITY) {\n await cleanupOldData();\n }\n\n // Constants\n const GREETING = \"שלום, הגעתם לבינה מלאכותית של מוטי כץ, מה תרצו לשאול\";\n const NOT_HEARD = \"לא שמעתי אותך, אנא נסה שוב\";\n const WRONG_CODE = \"קוד שגוי\";\n const REFUSAL_FALLBACK = \"מצטער, יש לי בעיה טכנית כרגע. נסה שוב בעוד רגע\";\n\n // Extract call data\n const latestRecording = extractLatestRecording(params);\n const nextVar = `rec${countRecordings(params) + 1}`;\n const callId = params.get(\"ApiCallId\") ||\n params.get(\"ApiPhone\") ||\n generateAnonCallId(params);\n\n console.log(`[CALL] id=${callId}, rec=${latestRecording || \"none\"}, next=${nextVar}`);\n\n // First request - play greeting\n if (!latestRecording) {\n return textResponse(buildReadResponse(GREETING, nextVar));\n }\n\n // Download recording\n const downloadStart = Date.now();\n const audio = await downloadRecording(latestRecording);\n console.log(`[TIME] Download: ${Date.now() - downloadStart}ms`);\n\n // Transcribe\n const whisperStart = Date.now();\n const userText = await transcribe(audio);\n console.log(`[TIME] Whisper: ${Date.now() - whisperStart}ms | \"${userText}\"`);\n\n if (!userText || userText.length < 2) {\n return textResponse(buildReadResponse(NOT_HEARD, nextVar));\n }\n\n // Get session state\n const session = await getSession(callId);\n\n // ─── UNLOCK CODE HANDLING ──────────────────────────────\n if (!session.unlocked) {\n if (detectUnlockCode(userText)) {\n await updateSession(callId, true, session.attempts);\n await saveExchange(callId, \"[code entered]\", \"[unlocked]\");\n console.log(`[UNLOCK] Call ${callId} unlocked`);\n return textResponse(buildReadResponse(\"מצב חופשי פעיל\", nextVar));\n }\n\n if (session.attempts < MAX_UNLOCK_ATTEMPTS && isPureDigitsMessage(userText)) {\n const newAttempts = session.attempts + 1;\n await updateSession(callId, false, newAttempts);\n console.log(`[UNLOCK] Wrong code attempt ${newAttempts}/${MAX_UNLOCK_ATTEMPTS}`);\n\n if (newAttempts >= MAX_UNLOCK_ATTEMPTS) {\n await clearSession(callId);\n return textResponse(\n \"id_list_message=t-יותר מדי ניסיונות. השיחה מנותקת.&go_to_folder=hangup\",\n );\n }\n\n return textResponse(buildReadResponse(WRONG_CODE, nextVar));\n }\n }\n\n // ─── CENSORSHIP (locked only, skipped when search triggers) ──\n const detection = needsSearch(userText);\n\n if (!session.unlocked && !detection.need) {\n // Layer 1: Forbidden keywords\n if (isForbiddenKeyword(userText)) {\n await saveExchange(callId, userText, \"[blocked:keyword]\");\n console.log(`[CENSOR] Blocked by keyword`);\n return textResponse(buildReadResponse(\n \"אני לא יכול לדבר על זה. אפשר לשאול משהו אחר?\",\n nextVar,\n ));\n }\n\n // Layer 2: Prompt injection\n if (await isPromptInjection(userText)) {\n await saveExchange(callId, userText, \"[blocked:injection]\");\n console.log(`[CENSOR] Blocked by injection detector`);\n return textResponse(buildReadResponse(\"אני לא יכול לענות על זה\", nextVar));\n }\n\n // Layer 3: Unsafe content\n if (await isUnsafeContent(userText)) {\n await saveExchange(callId, userText, \"[blocked:unsafe]\");\n console.log(`[CENSOR] Blocked by safety classifier`);\n return textResponse(buildReadResponse(\"אני לא יכול לענות על זה\", nextVar));\n }\n }\n\n // ─── BUILD MESSAGES ────────────────────────────────────\n const history = await getHistory(callId);\n const systemPrompt = session.unlocked ? UNRESTRICTED_PROMPT : RESTRICTED_PROMPT;\n\n const messages: { role: string; content: string }[] = [\n { role: \"system\", content: systemPrompt },\n ...history,\n ];\n\n // ─── SEARCH ────────────────────────────────────────────\n let finalUserMessage = userText;\n let searchContext = \"\";\n\n if (detection.need) {\n console.log(`[SEARCH] Triggered: ${detection.reason}`);\n searchContext = await searchTavily(userText);\n\n if (searchContext) {\n finalUserMessage = `${userText}\\n\\n\\n${searchContext}\\n`;\n } else {\n console.log(`[SEARCH] No context returned`);\n }\n }\n\n messages.push({ role: \"user\", content: finalUserMessage });\n\n // ─── ASK LLM ───────────────────────────────────────────\n const llmStart = Date.now();\n let answer = await askLLM(messages, systemPrompt);\n console.log(`[TIME] LLM: ${Date.now() - llmStart}ms`);\n\n // Refusal fallback: if LLM refused but we have search context\n if (detectRefusal(answer) && searchContext) {\n console.log(`[REFUSAL] LLM refused - retrying with direct context`);\n\n const directMessages = [\n { role: \"system\", content: systemPrompt },\n ...history,\n {\n role: \"user\",\n content: `${userText}\\n\\nמידע רלוונטי:\\n${searchContext}`,\n },\n ];\n\n answer = await askLLM(directMessages, systemPrompt);\n\n if (detectRefusal(answer)) {\n console.log(`[REFUSAL] Still refused - using fallback`);\n answer = REFUSAL_FALLBACK;\n }\n }\n\n // ─── SAVE + RESPOND ────────────────────────────────────\n await saveExchange(callId, userText, answer);\n\n console.log(`[TIME] TOTAL: ${Date.now() - requestStart}ms`);\n console.log(`[ANSWER] \"${answer.slice(0, 150)}\"`);\n\n return textResponse(buildReadResponse(answer, nextVar));\n\n } catch (error) {\n console.error(`[FATAL] After ${Date.now() - requestStart}ms:`, error);\n return textResponse(buildReadResponse(\"אירעה שגיאה, אנא נסה שוב\", \"rec1\"));\n }\n}\n","createdAt",["D",1789440449877],"branchVersion","branchId","b6c293e8-42f9-4df5-9f42-7baf71c54e5e","id","831ddbfb-7be1-410e-b10f-cceec33c95d2","VAL_DEEPSEEK",["D",1789429567305],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","","imageUrl","638ff93b-dc01-4e6c-a6fe-aeef60083c82","pinnedFileId","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","01a08d26-b22e-75da-9abf-ee563d18adc0","tursoName","831ddbfb7be1410eb10fcceec33c95d2","tursoHostname","831ddbfb7be1410eb10fcceec33c95d2-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789522252250],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_105":104,"_111":59},"org",{"_105":104,"_106":59,"_107":59,"_19":61,"_108":109,"_110":31},"branch",{"_13":94,"_38":95,"_49":48,"_96":50,"_97":-5,"_98":-5,"_99":-5,"_100":-5,"_101":-5,"_102":51,"_103":104},"isOwned",38,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","khny92162","handle","displayName","avatar","tier","free","canRestrictVals","profileImageUrl","branchName","adoptOrgId",{"_49":50,"_38":51,"_44":158,"_53":-5,"_54":31,"_55":56,"_57":56,"_58":59,"_60":-5,"_19":61,"_62":37,"_63":64,"_65":-5,"_66":-5,"_67":68,"_69":70,"_71":72,"_73":74,"_75":159,"_77":-5,"_78":79,"_80":79,"_81":82,"_83":82,"_84":82,"_85":79,"_86":79,"_87":160,"_89":161,"_91":162,"_93":31},"tree",[153],"files",[153],"counts",{"_141":68,"_142":143,"_144":68,"_145":146,"_147":148},"contents",[133],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_49":134,"_38":34,"_36":37,"_135":-5,"_47":48,"_46":14,"_136":31,"_44":137,"_13":138,"_39":40,"_41":43,"_30":31,"_139":-5,"_33":140},"00d76391-93da-4dfb-9d3e-29feb792f55c","parentId","latest",["D",1789440449877],19,"label",[34],"pulls","branches",1,"forks","envVars",{"_149":151,"_152":68},"connections",{"_149":68,"_150":68},"count","unfilledCount",6,"emptyCount",{"_49":134,"_38":34,"_36":37,"_135":-5,"_47":48,"_46":14,"_136":31,"_44":154,"_13":138,"_39":40,"_41":43,"_30":31,"_139":-5,"_155":156,"_33":157},["D",1789440449877],"children",[],[34],["D",1789429567305],["D",1789522252250],{"_105":104,"_111":59},{"_105":104,"_106":59,"_107":59,"_19":61,"_108":109,"_110":31},{"_13":94,"_38":95,"_49":48,"_96":50,"_97":-5,"_98":-5,"_99":-5,"_100":-5,"_101":-5,"_102":51,"_103":104},"ctx",{"_87":-5,"_130":196,"_197":198,"_199":200,"_201":31,"_202":31,"_203":31,"_204":64,"_205":-5,"_206":-7,"_207":-7,"_208":68,"_209":31,"_210":31,"_211":-5,"_212":31,"_213":31,"_214":31,"_215":-5},"ENV",{"_167":168,"_169":170,"_171":95,"_172":173,"_174":175,"_176":177,"_178":179,"_180":181,"_182":183,"_184":185,"_186":187,"_188":189,"_190":191,"_192":193,"_194":195},"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 · v22