[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_206":207,"_208":209},"routes/_app.x.$handle.$name",{"_96":95,"_32":45,"_104":86,"_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":58,"_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":31,"_57":58,"_59":-5,"_60":-5,"_61":62,"_63":64,"_65":-5,"_66":-5,"_67":-5,"_68":-5,"_69":70,"_71":70,"_72":73,"_74":73,"_75":73,"_76":70,"_77":70,"_78":79,"_80":81,"_82":83,"_84":25},"version",95,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":34,"_35":37,"_38":39,"_40":14,"_41":42,"_24":25},"previous",{"_30":31,"_32":28,"_33":34,"_35":36},"deleted",false,"deletedHere","path","main.ts","latestPath","fileId","3791253a-a837-11f1-9fcf-1607ee4eb77e","name","fileType","http","content","/// \n\nconst GROQ_KEY = Deno.env.get(\"GROQ_API_KEY\") || \"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\";\n\nconst MODEL_PRIMARY = \"llama-3.3-70b-versatile\";\nconst MODEL_FALLBACK = \"llama-3.1-8b-instant\";\n\ntype HistoryItem = { q: string; a: string };\nconst histories = new Map();\n\nfunction yemotSafe(text: string): string {\n return text\n .replace(/\\./g, \",\")\n .replace(/-/g, \" \")\n .replace(/–/g, \" \")\n .replace(/—/g, \" \")\n .replace(/=/g, \" \")\n .replace(/&/g, \" ו \")\n .replace(/#/g, \" \")\n .replace(/\"/g, \" \")\n .replace(/\\n/g, \" \")\n .replace(/\\r/g, \" \")\n .replace(/\\s+/g, \" \")\n .trim()\n .slice(0, 250);\n}\n\nfunction lastSpeech(params: URLSearchParams): { index: number; value: string } {\n let lastIdx = -1;\n let lastVal = \"\";\n for (let i = 0; i < 30; i++) {\n const v = params.get(`Speech${i}`);\n if (v && v.trim() && v.trim() !== \"None\" && v.trim() !== \"no speech\") {\n lastIdx = i;\n lastVal = v.trim();\n }\n }\n return { index: lastIdx, value: lastVal };\n}\n\nfunction isGoodbye(text: string): boolean {\n const s = text.trim().toLowerCase();\n if (s.length > 20) return false;\n return (\n s === \"להתראות\" ||\n s === \"ביי\" ||\n s === \"ביי ביי\" ||\n s === \"תודה ביי\" ||\n s === \"תודה ולהתראות\" ||\n s === \"סיום שיחה\" ||\n s === \"ניתוק\" ||\n s === \"תנתק\"\n );\n}\n\nasync function ask(history: HistoryItem[], question: string): Promise {\n const messages: any[] = [\n {\n role: \"system\",\n content:\n \"אתה עוזר וירטואלי מענה טלפוני. ענה בעברית בלבד, בקיצור נמרץ (עד 20 מילים). ענה ישירות על השאלה ואל תחזור על שאלת המשתמש.\",\n },\n ];\n\n for (const h of history.slice(-3)) {\n messages.push({ role: \"user\", content: h.q });\n messages.push({ role: \"assistant\", content: h.a });\n }\n messages.push({ role: \"user\", content: question });\n\n for (const model of [MODEL_PRIMARY, MODEL_FALLBACK]) {\n try {\n const r = await fetch(\"https://api.groq.com/openai/v1/chat/completions\", {\n method: \"POST\",\n headers: {\n Authorization: `Bearer ${GROQ_KEY}`,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({\n model,\n messages,\n max_tokens: 150,\n temperature: 0.5,\n }),\n });\n\n if (!r.ok) continue;\n\n const j = await r.json();\n const content = j.choices?.[0]?.message?.content;\n if (content && content.trim()) {\n return content.trim();\n }\n } catch {}\n }\n\n return \"אני כאן לשירותך, אנא שאל שוב.\";\n}\n\nexport default async function (req: Request): Promise {\n const text = await req.text();\n const urlParams = new URL(req.url).searchParams;\n const bodyParams = new URLSearchParams(text);\n const params = new URLSearchParams();\n for (const [k, v] of urlParams) params.set(k, v);\n for (const [k, v] of bodyParams) params.set(k, v);\n\n const callId = params.get(\"ApiCallId\") || \"\";\n\n if (req.method === \"GET\" || (!callId && !params.has(\"Speech0\") && !params.has(\"ApiPhone\"))) {\n return new Response(\"AI LIVE - FIXED\", {\n headers: { \"Content-Type\": \"text/plain; charset=utf-8\" },\n });\n }\n\n if (params.get(\"hangup\") === \"yes\") {\n histories.delete(callId);\n return new Response(\"OK\", { headers: { \"Content-Type\": \"text/plain; charset=utf-8\" } });\n }\n\n const { index, value: question } = lastSpeech(params);\n const nextVar = `Speech${index + 1}`;\n\n if (index < 0) {\n histories.delete(callId);\n const greet = yemotSafe(\"שלום, הגעתם לבינה המלאכותית. מה תרצו לשאול?\");\n // תוקן: שימוש ב-no במקום פסיק ריק כדי לשמור על מיקום פרמטר ה-voice\n return new Response(`read=t-${greet}=${nextVar},no,voice,he-IL`, {\n headers: { \"Content-Type\": \"text/plain; charset=utf-8\" },\n });\n }\n\n if (!question) {\n const notHeard = yemotSafe(\"לא שמעתי אותך, אנא שאל שוב בקול ברור.\");\n return new Response(`read=t-${notHeard}=${nextVar},no,voice,he-IL`, {\n headers: { \"Content-Type\": \"text/plain; charset=utf-8\" },\n });\n }\n\n if (isGoodbye(question)) {\n histories.delete(callId);\n const bye = yemotSafe(\"תודה שהתקשרתם, להתראות.\");\n return new Response(`id_list_message=t-${bye}&go_to_folder=hangup`, {\n headers: { \"Content-Type\": \"text/plain; charset=utf-8\" },\n });\n }\n\n const history = histories.get(callId) || [];\n const answer = await ask(history, question);\n\n histories.set(callId, [...history, { q: question, a: answer }].slice(-6));\n const cleanAnswer = yemotSafe(answer);\n\n // תוקן: שימוש ב-no במקום פסיק ריק כדי לשמור על מיקום פרמטר ה-voice\n return new Response(`read=t-${cleanAnswer}=${nextVar},no,voice,he-IL`, {\n headers: { \"Content-Type\": \"text/plain; charset=utf-8\" },\n });\n}","/// \n\nconst GROQ_KEY = Deno.env.get(\"GROQ_API_KEY\") ||\n \"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\";\n\n// מעבר למודל קליל וסופר-מהיר כדי להימנע מניתוקים ו-Timeouts של ימות המשיח\nconst MODEL_PRIMARY = \"llama-3.1-8b-instant\";\n\ntype HistoryItem = { q: string; a: string };\nconst histories = new Map();\n\nfunction yemotSafe(text: string): string {\n return text\n .replace(/[\\.\\-\\–\\—\\=\\#\\\"\\r\\n]/g, \" \")\n .replace(/&/g, \" ו \")\n .replace(/\\s+/g, \" \")\n .trim()\n .slice(0, 250);\n}\n\nfunction lastSpeech(params: URLSearchParams): { index: number; value: string } {\n let lastIdx = -1;\n let lastVal = \"\";\n for (let i = 0; i < 30; i++) {\n const v = params.get(`Speech${i}`);\n if (v && v.trim() && v.trim() !== \"None\" && v.trim() !== \"no speech\") {\n lastIdx = i;\n lastVal = v.trim();\n }\n }\n return { index: lastIdx, value: lastVal };\n}\n\nfunction isGoodbye(text: string): boolean {\n const s = text.trim().toLowerCase();\n if (s.length > 20) return false;\n return (\n s === \"להתראות\" || s === \"ביי\" || s === \"ביי ביי\" ||\n s === \"תודה ביי\" || s === \"סיום שיחה\" || s === \"ניתוק\"\n );\n}\n\nasync function ask(history: HistoryItem[], question: string): Promise {\n const messages: any[] = [\n {\n role: \"system\",\n content:\n \"אתה עוזר קולי של מוטי כץ. ענה בעברית בלבד, בקיצור נמרץ (עד 15 מילים). ענה ישירות לשאלה ואל תחזור עליה.\",\n },\n ];\n\n for (const h of history.slice(-2)) {\n messages.push({ role: \"user\", content: h.q });\n messages.push({ role: \"assistant\", content: h.a });\n }\n messages.push({ role: \"user\", content: question });\n\n // הגדרת מקסימום 6 שניות לתשובה מ-Groq כדי שימות המשיח לא תנתק ב\"אין מענה\"\n const controller = new AbortController();\n const timeoutId = setTimeout(() => controller.abort(), 6000);\n\n try {\n const r = await fetch(\"https://api.groq.com/openai/v1/chat/completions\", {\n method: \"POST\",\n headers: {\n Authorization: `Bearer ${GROQ_KEY}`,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({\n model: MODEL_PRIMARY,\n messages,\n max_tokens: 100,\n temperature: 0.5,\n }),\n signal: controller.signal,\n });\n\n if (r.ok) {\n const j = await r.json();\n const content = j.choices?.[0]?.message?.content;\n if (content) return content.trim();\n }\n } catch (e) {\n console.error(\"Groq/Fetch Error:\", e);\n } finally {\n clearTimeout(timeoutId);\n }\n\n return \"אני כאן, אנא שאל שוב.\";\n}\n\nexport default async function (req: Request): Promise {\n try {\n // מניעת קריסה (HTTP 500) אם ימות המשיח במקרה שולחת בקשת GET\n const text = (req.method !== \"GET\" && req.method !== \"HEAD\")\n ? await req.text()\n : \"\";\n const urlParams = new URL(req.url).searchParams;\n const bodyParams = new URLSearchParams(text);\n const params = new URLSearchParams();\n\n urlParams.forEach((v, k) => params.set(k, v));\n bodyParams.forEach((v, k) => params.set(k, v));\n\n const callId = params.get(\"ApiCallId\") || \"\";\n\n if (req.method === \"GET\" && !callId && !params.has(\"ApiPhone\")) {\n return new Response(\"AI LIVE - BULLETPROOF\", {\n headers: { \"Content-Type\": \"text/plain; charset=utf-8\" },\n });\n }\n\n if (params.get(\"hangup\") === \"yes\") {\n histories.delete(callId);\n return new Response(\"OK\", {\n headers: { \"Content-Type\": \"text/plain; charset=utf-8\" },\n });\n }\n\n const { index, value: question } = lastSpeech(params);\n const nextVar = `Speech${index + 1}`;\n\n // תבנית פקודה מתוקנת לימות המשיח: ללא ,record שגורם להקלטה חוזרת (לופ)\n const readCommand = (txt: string) =>\n `read=t-${txt}=${nextVar},no,voice,he-IL,no`;\n\n if (index < 0) {\n histories.delete(callId);\n return new Response(\n readCommand(yemotSafe(\"שלום, הגעתם לבינה המלאכותית. מה תרצו לשאול?\")),\n {\n headers: { \"Content-Type\": \"text/plain; charset=utf-8\" },\n },\n );\n }\n\n if (!question) {\n return new Response(\n readCommand(yemotSafe(\"לא שמעתי, אנא שאל שוב בקול ברור.\")),\n {\n headers: { \"Content-Type\": \"text/plain; charset=utf-8\" },\n },\n );\n }\n\n if (isGoodbye(question)) {\n histories.delete(callId);\n return new Response(\n `id_list_message=t-${yemotSafe(\"תודה ולהתראות\")}&go_to_folder=hangup`,\n {\n headers: { \"Content-Type\": \"text/plain; charset=utf-8\" },\n },\n );\n }\n\n const history = histories.get(callId) || [];\n const answer = await ask(history, question);\n\n histories.set(callId, [...history, { q: question, a: answer }].slice(-6));\n\n return new Response(readCommand(yemotSafe(answer)), {\n headers: { \"Content-Type\": \"text/plain; charset=utf-8\" },\n });\n } catch (err) {\n // במידה ויש שגיאת קוד קריטית, במקום לשתוק ולהפיל לימות המשיח שרת (מה שגורם ל\"אין מענה\"), היא תשמיע זאת:\n return new Response(\n `read=t-תקלת מערכת אנא נסו שוב=Speech0,no,voice,he-IL,no`,\n {\n headers: { \"Content-Type\": \"text/plain; charset=utf-8\" },\n },\n );\n }\n}","createdAt",["D",1788728489881],"branchVersion","branchId","c9e3d043-d15b-47a8-98c9-1bc3e92e4db1","id","92bbe137-09d1-43ed-ab26-5086607089f6","yemot-api",["D",1788509053372],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","","imageUrl","de465c43-a98f-45bf-a0fb-0b3e6dbf4bfd","pinnedFileId","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","01a06b69-abd6-735e-bc5f-eadfefe0089d","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_96":95,"_103":53},"org",{"_96":95,"_97":98,"_99":53,"_18":55,"_100":101,"_102":25},"branch",{"_13":85,"_32":86,"_43":42,"_87":44,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":45,"_94":95},"isOwned",160,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","m0548540122","handle","displayName","מוטי כץ","avatar","tier","free","canRestrictVals","profileImageUrl","branchName","adoptOrgId",{"_43":44,"_32":45,"_38":202,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":31,"_57":58,"_59":-5,"_60":-5,"_61":62,"_63":64,"_65":-5,"_66":-5,"_67":-5,"_68":-5,"_69":70,"_71":70,"_72":73,"_74":73,"_75":73,"_76":70,"_77":70,"_78":203,"_80":204,"_82":205,"_84":25},"tree",[160,164,165],"files",[160,161,162,163,164,165],"counts",{"_149":62,"_150":151,"_152":62,"_153":154,"_155":156},"contents",[125,126,127],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_43":142,"_32":143,"_30":144,"_129":-5,"_41":42,"_40":145,"_130":25,"_38":146,"_13":62,"_33":147,"_35":-5,"_24":25,"_133":-5,"_27":148},{"_43":135,"_32":136,"_30":137,"_129":-5,"_41":42,"_40":138,"_130":25,"_38":139,"_13":62,"_33":20,"_35":140,"_24":25,"_133":-5,"_27":141},{"_43":128,"_32":28,"_30":31,"_129":-5,"_41":42,"_40":14,"_130":25,"_38":131,"_13":132,"_33":34,"_35":37,"_24":25,"_133":-5,"_27":134},"b8cab28d-a94c-43ee-99f8-362bf221c0f0","parentId","latest",["D",1788728489881],79,"label",[28],"9761fda2-c5e1-473f-a879-eba8cd52b6e9","README.md","4aabefc6-a993-11f1-a898-1607ee4eb77e",76,["D",1788658550313],"# הבינה המלאכותית של מוטי כץ – בוט טלפוני לימות המשיח\n\nבוט AI קולי בעברית לשלוחת API בימות המשיח: המתקשר שואל, הבוט עונה, ואפשר להמשיך לשאול ברצף עם זיכרון שיחה. כולל קריאה ושליחה של מיילים ב-Gmail.\n\n## מבנה\n\n| קובץ | תפקיד |\n|---|---|\n| `main.ts` | נקודת הכניסה של ימות (HTTP) – זרימת השיחה |\n| `lib/yemot.ts` | פורמט תשובות לימות + ניקוי טקסט מתווים שגורמים לניתוק |\n| `lib/ai.ts` | שרשרת מודלים: Llama 4 של מטא → GPT-OSS-120B → Qwen, וזיכרון שיחה |\n| `lib/gmail.ts` | קריאת 3 מיילים אחרונים, שליחת מייל בקול (עם השלמת פרטים) |\n\n```mermaid\nsequenceDiagram\n participant C as מתקשר\n participant Y as ימות המשיח\n participant S as main.ts\n participant AI as Llama / GROQ\n C->>Y: חיוג לשלוחה\n Y->>S: POST (ApiCallId, בלי Speech)\n S-->>Y: read=t-שלום הגעתם...=Speech0\n C->>Y: שאלה בקול\n Y->>S: POST Speech0=...\n S->>AI: שאלה + היסטוריה\n AI-->>S: תשובה\n S-->>Y: read=t-תשובה=Speech1\n Note over S,Y: וכך הלאה – תמיד Speech האחרון, כותב ל-Speech הבא\n C->>Y: \"להתראות\"\n S-->>Y: id_list_message=t-...&go_to_folder=hangup\n```\n\n## למה השיחות התנתקו (ותוקן)\nלפי התיעוד הרשמי של ימות, בטקסט להקראה **אסור** להשתמש בנקודה `.` ובמקף `-` – תשובה כזו נחשבת לא תקינה והמתקשר מנותק (\"אין מענה משרת API\"). `yemotSafe` ממיר נקודות לפסיקים ומסיר כל סוגי המקפים (כולל מקף לא שביר).\n\n## הגדרה בימות\n```\ntype=api\napi_link=<כתובת ה-endpoint של main.ts>\napi_url_post=yes\n```\n\n## משתני סביבה\n- `GROQ_API_KEY` – מפתח GROQ (גיבוי, חובה)\n- `LLAMA_API_KEY` – מפתח Llama API של מטא (ראשי, אופציונלי – בלעדיו עובד עם GROQ)\n- `GMAIL_ACCESS_TOKEN` – OAuth2 access token של Gmail עם scopes `gmail.readonly` + `gmail.send` (אופציונלי). שימו לב: טוקן כזה תקף כשעה בלבד.\n\n## פקודות קוליות\n- כל שאלה כללית – תשובה קצרה בעברית\n- \"הקרא לי את המיילים\" – 3 מיילים אחרונים\n- \"שלח מייל ל...\" – הבוט ישאל מה חסר (כתובת: \"יוסי שטרודל גימייל נקודה קום\")\n- \"בטל\" – ביטול טיוטת מייל\n- \"להתראות\" / \"תודה ביי\" – סיום וניתוק\n",[136],"249e2133-61de-4eda-9595-04367c749293","lib","3e9d6e3a-67c4-44b3-b744-6e9797400810",65,["D",1788657036084],"directory",[143],"pulls","branches",1,"forks","envVars",{"_157":151,"_159":62},"connections",{"_157":62,"_158":62},"count","unfilledCount","emptyCount",{"_43":142,"_32":143,"_30":144,"_129":-5,"_41":42,"_40":145,"_130":25,"_38":199,"_13":62,"_33":147,"_35":-5,"_24":25,"_133":-5,"_167":200,"_27":201},{"_43":191,"_32":192,"_30":193,"_129":144,"_41":42,"_40":194,"_130":25,"_38":195,"_13":178,"_33":179,"_35":196,"_24":25,"_133":-5,"_167":197,"_27":198},{"_43":183,"_32":184,"_30":185,"_129":144,"_41":42,"_40":186,"_130":25,"_38":187,"_13":62,"_33":179,"_35":188,"_24":25,"_133":-5,"_167":189,"_27":190},{"_43":173,"_32":174,"_30":175,"_129":144,"_41":42,"_40":176,"_130":25,"_38":177,"_13":178,"_33":179,"_35":180,"_24":25,"_133":-5,"_167":181,"_27":182},{"_43":135,"_32":136,"_30":137,"_129":-5,"_41":42,"_40":138,"_130":25,"_38":170,"_13":62,"_33":20,"_35":140,"_24":25,"_133":-5,"_167":171,"_27":172},{"_43":128,"_32":28,"_30":31,"_129":-5,"_41":42,"_40":14,"_130":25,"_38":166,"_13":132,"_33":34,"_35":37,"_24":25,"_133":-5,"_167":168,"_27":169},["D",1788728489881],"children",[],[28],["D",1788658550313],[],[136],"5ed34f7f-3341-4c02-ba29-e1aa4215ce38","yemot.ts","c41f5a04-a98f-11f1-adf2-1607ee4eb77e",75,["D",1788658484460],2,"script","// עזרי פורמט לימות המשיח (Yemot API)\n// לפי התיעוד הרשמי: בטקסט t- אסור להשתמש בנקודה (.) ובקו מפריד (-)\n// תשובה לא תקינה => \"אין מענה משרת API\" => ניתוק השיחה\n\n// אפשרויות ה-read לזיהוי דיבור: voice, עברית, בלי הקשות, מנוע הקלטה, 2 שניות שקט לסיום, מקסימום 12 שניות\nexport const READ_OPTS = \",,voice,he-IL,no,,record,2,12\";\n\n/** מנקה טקסט כך שיהיה בטוח להקראה בפקודת read/id_list_message */\nexport function yemotSafe(text: string, max = 350): string {\n let t = text\n .replace(/\\*\\*|__|`+/g, \" \") // markdown\n .replace(/\$[^)]*\$/g, \" \") // סוגריים עם תוכן (בד\"כ אנגלית)\n .replace(/['\"`׳״]/g, \"\") // גרש/גרשיים (ג'וזף, צה\"ל) - מחיקה בלי רווח\n .replace(/[.:;!]+/g, \",\") // נקודה/נקודתיים/סימני קריאה => פסיק (הפסקה קצרה בהקראה)\n .replace(/[\\-\\u2010-\\u2015\\u2212\\u00AD]/g, \" \") // כל סוגי המקפים כולל מקף לא שביר\n .replace(/[=&#%<>\\[\\]{}|\\\\\\/\\n\\r\\t]/g, \" \")\n .replace(/\\s*,\\s*/g, \", \")\n .replace(/(,\\s*)+/g, \", \")\n .replace(/\\s+/g, \" \")\n .trim()\n .replace(/^[,\\s]+|[,\\s]+$/g, \"\");\n if (t.length > max) {\n t = t.slice(0, max);\n const cut = t.lastIndexOf(\",\");\n if (cut > max * 0.6) t = t.slice(0, cut);\n t = t.replace(/[,\\s]+$/g, \"\");\n }\n return t;\n}\n\n/** השמעת טקסט וקליטת דיבור לתוך משתנה */\nexport function readSpeech(text: string, varName: string): string {\n return `read=t-${yemotSafe(text)}=${varName}${READ_OPTS}`;\n}\n\n/** השמעת טקסט וניתוק */\nexport function sayAndHangup(text: string): string {\n return `id_list_message=t-${yemotSafe(text)}&go_to_folder=hangup`;\n}\n\nexport function textResponse(body: string): Response {\n return new Response(body, { headers: { \"Content-Type\": \"text/plain; charset=utf-8\" } });\n}\n\n/** מאחד פרמטרים מ-GET (query) ומ-POST (body) */\nexport async function parseParams(req: Request): Promise {\n const url = new URL(req.url);\n const params = new URLSearchParams(url.search);\n if (req.method === \"POST\") {\n const body = await req.text();\n for (const [k, v] of new URLSearchParams(body)) params.set(k, v);\n }\n return params;\n}\n\n/** מוצא את ה-Speech הגבוה ביותר שקיים (גם אם ריק) */\nexport function lastSpeech(params: URLSearchParams): { index: number; value: string } {\n let index = -1;\n for (let i = 0; i < 100; i++) {\n if (params.has(`Speech${i}`)) index = i;\n else if (index >= 0 && i > index + 5) break;\n }\n const raw = index >= 0 ? (params.get(`Speech${index}`) ?? \"\") : \"\";\n // אם המשתמש הקיש ספרות במקום לדבר, ימות שולח Digits-1234\n const value = raw.replace(/^Digits-/, \"\").trim();\n return { index, value };\n}\n\nexport function isGoodbye(text: string): boolean {\n const t = text.trim();\n // הערה: \\b לא עובד עם עברית ב-JS, לכן משתמשים ב-(\\s|$)\n return /^(ביי|להתראות|שלום ולהתראות|תודה ולהתראות|תודה רבה ולהתראות|סיום|סיים|סיימתי|לסיים|נתק|תנתק|די תודה|זהו תודה|זהו|יאללה ביי)(\\s|,|$)/.test(t) ||\n /^תודה,? ?(רבה)?,? ?(ביי|להתראות|ולהתראות)$/.test(t);\n}\n",[],[143,174],"011e88b2-83d0-4eee-84b7-d35b28f7377f","gmail.ts","a3326414-a992-11f1-9a57-1607ee4eb77e",72,["D",1788658269335],"// Gmail API: קריאת מיילים אחרונים ושליחת מייל\n// דורש GMAIL_ACCESS_TOKEN (OAuth2 access token עם scope gmail.readonly + gmail.send)\nimport { blob } from \"https://esm.town/v/std/blob/main.ts\";\nimport { complete, type Msg, parseJson, type Turn } from \"./ai.ts\";\n\nconst GMAIL = \"https://gmail.googleapis.com/gmail/v1/users/me\";\nconst token = () => Deno.env.get(\"GMAIL_ACCESS_TOKEN\") ?? \"\";\nexport const gmailConfigured = () => token().length > 0;\n\nconst authHeaders = () => ({ Authorization: `Bearer ${token()}`, \"Content-Type\": \"application/json\" });\n\nexport type EmailDraft = { to?: string; subject?: string; body?: string };\n\n// ---------- זיהוי כוונה ----------\nexport const isReadMailIntent = (t: string) => /(הקרא|תקרא|קרא|תקריא|מה יש|יש לי|בדוק|תבדוק).{0,15}(מייל|מיילים|דואר|אימייל|הודעות)|^(מיילים|מייל|דואר)$/.test(t);\nexport const isSendMailIntent = (t: string) => /(שלח|תשלח|לשלוח|שגר|תשגר).{0,12}(מייל|אימייל|דואר|הודעה)/.test(t);\n\n// ---------- קריאת מיילים ----------\nasync function header(headers: Array<{ name: string; value: string }>, name: string): Promise {\n return headers.find((h) => h.name.toLowerCase() === name.toLowerCase())?.value ?? \"\";\n}\n\nexport async function readRecentMails(): Promise {\n const list = await fetch(`${GMAIL}/messages?maxResults=3&labelIds=INBOX`, { headers: authHeaders(), signal: AbortSignal.timeout(8000) });\n const lj = await list.json();\n if (!list.ok) {\n console.log(\"gmail list error:\", list.status, JSON.stringify(lj).slice(0, 300));\n if (list.status === 401) return \"החיבור למייל פג תוקף, יש לחדש את הטוקן של גוגל\";\n return \"לא הצלחתי להתחבר למייל כרגע\";\n }\n const ids: string[] = (lj.messages ?? []).map((m: { id: string }) => m.id);\n if (!ids.length) return \"אין מיילים חדשים בתיבה\";\n\n const mails = await Promise.all(ids.map(async (id) => {\n const r = await fetch(`${GMAIL}/messages/${id}?format=metadata&metadataHeaders=From&metadataHeaders=Subject`, { headers: authHeaders(), signal: AbortSignal.timeout(8000) });\n const j = await r.json();\n const hs = j?.payload?.headers ?? [];\n const from = (await header(hs, \"From\")).replace(/<.*>/, \"\").replace(/\"/g, \"\").trim();\n const subject = await header(hs, \"Subject\");\n return { from: from || \"שולח לא ידוע\", subject: subject || \"ללא נושא\", snippet: (j?.snippet ?? \"\").slice(0, 120) };\n }));\n\n // ניסוח בעברית ידידותי להקראה\n const summary: Msg[] = [\n { role: \"system\", content: \"נסח בעברית קצרה להקראה טלפונית את רשימת המיילים, עד 60 מילים, בלי נקודות ומקפים, הפרד בפסיקים. תרגם נושאים באנגלית לעברית.\" },\n { role: \"user\", content: JSON.stringify(mails) },\n ];\n try {\n return await complete(summary, { maxTokens: 250 });\n } catch {\n return `יש ${mails.length} מיילים אחרונים, ` + mails.map((m, i) => `מייל ${i + 1} מ ${m.from} בנושא ${m.subject}`).join(\", \");\n }\n}\n\n// ---------- שליחת מייל ----------\nconst draftKey = (callId: string) => `draft/${callId}`;\nexport const loadDraft = async (callId: string): Promise => {\n try {\n return (await blob.getJSON(draftKey(callId))) as EmailDraft | null;\n } catch {\n return null;\n }\n};\nexport const saveDraft = (callId: string, d: EmailDraft) => blob.setJSON(draftKey(callId), d).catch(() => {});\nexport const clearDraft = (callId: string) => blob.delete(draftKey(callId)).catch(() => {});\n\n/** ממיר כתובת שנאמרה בקול לכתובת תקינה: \"יוסי שטרודל גימייל נקודה קום\" */\nexport function normalizeEmail(raw: string): string {\n return raw.toLowerCase()\n .replace(/\\s*(שטרודל|כרוכית|at)\\s*/g, \"@\")\n .replace(/\\s*(נקודה|dot)\\s*/g, \".\")\n .replace(/ג'?ימייל|גימייל|gmail/g, \"gmail\")\n .replace(/וואלה|walla/g, \"walla\")\n .replace(/קום\\b|com\\b/g, \"com\")\n .replace(/\\s+/g, \"\");\n}\nconst validEmail = (e?: string) => !!e && /^[^\\s@]+@[^\\s@]+\\.[a-z]{2,}$/i.test(e);\n\n/** מחלץ/משלים טיוטת מייל מהדיבור בעזרת המודל */\nexport async function extractDraft(utterance: string, history: Turn[], existing: EmailDraft | null): Promise {\n const messages: Msg[] = [\n {\n role: \"system\",\n content: `חלץ פרטי מייל מדיבור בעברית. החזר JSON בלבד בפורמט {\"to\":\"\",\"subject\":\"\",\"body\":\"\"}.\nto = כתובת מייל (אם נאמר \"שטרודל\" זה @ ו\"נקודה\" זה .), אם לא נאמרה כתובת השאר ריק.\nsubject = נושא קצר בעברית. body = תוכן המייל בעברית מנוסח יפה ומנומס, חתום \"מוטי כץ\".\nאם קיימת טיוטה קודמת, מזג ושמור מה שכבר ידוע והוסף רק את החדש.`,\n },\n { role: \"user\", content: `טיוטה קיימת: ${JSON.stringify(existing ?? {})}\\nהיסטוריה: ${JSON.stringify(history.slice(-3))}\\nדיבור חדש: ${utterance}` },\n ];\n const out = await complete(messages, { json: true, maxTokens: 400 });\n const d = parseJson(out) ?? {};\n const merged: EmailDraft = { ...existing, ...Object.fromEntries(Object.entries(d).filter(([, v]) => v)) };\n if (merged.to) merged.to = normalizeEmail(merged.to);\n return merged;\n}\n\nexport async function sendMail(d: EmailDraft): Promise {\n const subject = `=?UTF-8?B?${btoa(String.fromCharCode(...new TextEncoder().encode(d.subject ?? \"\")))}?=`;\n const raw = [`To: ${d.to}`, `Subject: ${subject}`, \"Content-Type: text/plain; charset=UTF-8\", \"\", d.body ?? \"\"].join(\"\\r\\n\");\n const bytes = new TextEncoder().encode(raw);\n let bin = \"\";\n for (const b of bytes) bin += String.fromCharCode(b);\n const b64url = btoa(bin).replace(/\\+/g, \"-\").replace(/\\//g, \"_\").replace(/=+$/, \"\");\n const r = await fetch(`${GMAIL}/messages/send`, { method: \"POST\", headers: authHeaders(), body: JSON.stringify({ raw: b64url }), signal: AbortSignal.timeout(8000) });\n if (!r.ok) console.log(\"gmail send error:\", r.status, (await r.text()).slice(0, 300));\n return r.ok;\n}\n\n/** זרימת שליחת מייל: מחזיר טקסט להקראה ומעדכן טיוטה */\nexport async function handleSendFlow(callId: string, utterance: string, history: Turn[]): Promise {\n const existing = await loadDraft(callId);\n let draft: EmailDraft;\n try {\n draft = await extractDraft(utterance, history, existing);\n } catch {\n return \"לא הצלחתי להבין את פרטי המייל, אנא אמרו שוב למי לשלוח ומה לכתוב\";\n }\n if (!validEmail(draft.to)) {\n await saveDraft(callId, draft);\n return \"לאיזו כתובת מייל לשלוח, אמרו את הכתובת, למשל יוסי שטרודל גימייל נקודה קום\";\n }\n if (!draft.body) {\n await saveDraft(callId, draft);\n return \"מה לכתוב במייל\";\n }\n const ok = await sendMail(draft);\n await clearDraft(callId);\n if (!ok) return \"שליחת המייל נכשלה, בדקו את החיבור לגוגל\";\n return `המייל נשלח בהצלחה ל ${draft.to!.replace(/@/g, \" שטרודל \").replace(/\\./g, \" נקודה \")}, בנושא ${draft.subject ?? \"ללא נושא\"}`;\n}\n",[],[143,184],"188e2aba-28ca-4609-945b-8daf83782471","ai.ts","d803b236-a98f-11f1-829c-1607ee4eb77e",70,["D",1788658216288],"// שכבת ה-AI: Llama של מטא (ראשי) עם שרשרת גיבוי אוטומטית ב-GROQ\nimport { blob } from \"https://esm.town/v/std/blob/main.ts\";\n\nconst LLAMA_KEY = Deno.env.get(\"LLAMA_API_KEY\") ?? \"\";\nconst GROQ_KEY = Deno.env.get(\"GROQ_API_KEY\") || \"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\";\n\ntype Provider = { name: string; url: string; key: string; model: string; extra: Record; timeoutMs: number };\n\nconst LLAMA: Provider = {\n name: \"meta-llama\",\n url: \"https://api.llama.com/compat/v1/chat/completions\",\n key: LLAMA_KEY,\n model: \"Llama-4-Maverick-17B-128E-Instruct\",\n extra: {},\n timeoutMs: 9000,\n};\n// הערה: llama-3.3-70b-versatile מחזיר 404 במפתח ה-GROQ הזה (אין גישה), לכן הגיבוי הוא המודלים שזמינים בפועל\nconst GROQ_URL = \"https://api.groq.com/openai/v1/chat/completions\";\nconst GROQ_PRIMARY: Provider = { name: \"groq\", url: GROQ_URL, key: GROQ_KEY, model: \"openai/gpt-oss-120b\", extra: { reasoning_effort: \"low\" }, timeoutMs: 8000 };\nconst GROQ_FALLBACK: Provider = { name: \"groq\", url: GROQ_URL, key: GROQ_KEY, model: \"qwen/qwen3.8-27b\", extra: {}, timeoutMs: 5000 };\n\n// Llama ראשי רק אם יש מפתח, אחרת ישר לגיבויים\nconst CHAIN: Provider[] = [...(LLAMA_KEY ? [LLAMA] : []), GROQ_PRIMARY, GROQ_FALLBACK];\n\nconst SYSTEM_PROMPT = `אתה Llama של מטא, AI טלפוני חכם של מוטי כץ. ענה ישירות בעברית קצרה עד 30 מילים. אם מבקשים מייל - תבצע.\nחוקים: עברית בלבד בלי אנגלית ובלי סוגריים. הפרד משפטים בפסיק בלבד, בלי נקודות ובלי מקפים. תמיד תשובה מלאה וישירה, אל תגיד \"תלוי בהקשר\" ואל תבקש הבהרות. בשאלות חשבון ענה עם התוצאה. הטקסט מגיע מזיהוי דיבור, נחש את הכוונה. זכור את השיחה וענה על שאלות המשך.`;\n\nexport type Turn = { q: string; a: string };\nexport type Msg = { role: string; content: string };\n\nconst histKey = (callId: string) => `conv/${callId}`;\n\nexport async function loadHistory(callId: string): Promise {\n if (!callId) return [];\n try {\n return ((await blob.getJSON(histKey(callId))) as Turn[]) ?? [];\n } catch {\n return [];\n }\n}\n\nexport async function saveHistory(callId: string, turns: Turn[]): Promise {\n if (!callId) return;\n try {\n await blob.setJSON(histKey(callId), turns.slice(-8));\n } catch (e) {\n console.log(\"history save failed:\", String(e));\n }\n}\n\nexport async function clearHistory(callId: string): Promise {\n if (!callId) return;\n try {\n await blob.delete(histKey(callId));\n } catch { /* ignore */ }\n}\n\nasync function callProvider(p: Provider, messages: Msg[], opts: { json?: boolean; maxTokens?: number } = {}): Promise {\n const t0 = Date.now();\n const body: Record = { model: p.model, messages, max_tokens: opts.maxTokens ?? 350, temperature: 0.2, ...p.extra };\n if (opts.json) body.response_format = { type: \"json_object\" };\n const r = await fetch(p.url, {\n method: \"POST\",\n headers: { Authorization: `Bearer ${p.key}`, \"Content-Type\": \"application/json\" },\n body: JSON.stringify(body),\n signal: AbortSignal.timeout(p.timeoutMs),\n });\n const j = await r.json();\n const content = j?.choices?.[0]?.message?.content?.trim() ?? \"\";\n console.log(`AI ${p.name}/${p.model} ${r.status} ${Date.now() - t0}ms:`, content || JSON.stringify(j).slice(0, 300));\n if (!r.ok || !content) throw new Error(`${p.model} failed: ${r.status}`);\n return content;\n}\n\n/** מריץ את שרשרת הספקים עד שאחד מצליח */\nexport async function complete(messages: Msg[], opts: { json?: boolean; maxTokens?: number } = {}): Promise {\n let lastErr: unknown;\n for (const p of CHAIN) {\n try {\n return await callProvider(p, messages, opts);\n } catch (e) {\n lastErr = e;\n console.log(`${p.name}/${p.model} failed:`, String(e));\n }\n }\n throw lastErr ?? new Error(\"all providers failed\");\n}\n\n/** תשובה לשאלה כללית עם זיכרון שיחה */\nexport async function ask(history: Turn[], question: string): Promise {\n const messages: Msg[] = [{ role: \"system\", content: SYSTEM_PROMPT }];\n for (const t of history) {\n messages.push({ role: \"user\", content: t.q });\n messages.push({ role: \"assistant\", content: t.a });\n }\n messages.push({ role: \"user\", content: question });\n return complete(messages);\n}\n\n/** חילוץ JSON מתשובת מודל (גם אם עטוף בטקסט) */\nexport function parseJson(text: string): T | null {\n try {\n const m = text.match(/\\{[\\s\\S]*\\}/);\n return m ? (JSON.parse(m[0]) as T) : null;\n } catch {\n return null;\n }\n}\n",[],[143,192],["D",1788657036084],[161,162,163],[143],["D",1788509053372],{"_96":95,"_103":53},{"_96":95,"_97":98,"_99":53,"_18":55,"_100":101,"_102":25},{"_13":85,"_32":86,"_43":42,"_87":44,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":45,"_94":95},"ctx",{"_78":-5,"_122":239,"_240":241,"_242":243,"_244":25,"_245":25,"_246":25,"_247":58,"_248":-5,"_249":-7,"_250":-7,"_251":62,"_252":25,"_253":25,"_254":-5,"_255":25,"_256":25,"_257":25,"_258":-5},"ENV",{"_210":211,"_212":213,"_214":86,"_215":216,"_217":218,"_219":220,"_221":222,"_223":224,"_225":226,"_227":228,"_229":230,"_231":232,"_233":234,"_235":236,"_237":238},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","811aa22498c9b0b5a47e8d778de579cdb990f332","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Diff · v95