[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_166":167,"_168":169},"routes/_app.x.$handle.$name",{"_94":93,"_32":45,"_102":84,"_27":97,"_13":14,"_103":-5,"_11":104,"_105":106,"_107":108,"_109":110,"_111":112,"_20":-5,"_113":-5,"_114":-5,"_115":25,"_116":117,"_118":119,"_120":-5,"_121":-5,"_122":123},"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":-5,"_53":-5,"_18":54,"_55":-5,"_56":25,"_57":-5,"_58":-5,"_59":60,"_61":62,"_63":-5,"_64":-5,"_65":-5,"_66":-5,"_67":68,"_69":68,"_70":71,"_72":71,"_73":71,"_74":68,"_75":68,"_76":77,"_78":79,"_80":81,"_82":25},"version",15,"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","e18331bc-401f-11f1-b553-42b51c65c3df","name","fileType","http","content","// Personal assistant bot — agentic version with tool use\n// Drop-in replacement for telegram-bot-h2c.ts. Same env vars.\n// Create a SECOND val so you can A/B against the working classifier version.\n\nimport {\n create as createJWT,\n getNumericDate,\n} from \"https://deno.land/x/djwt@v3.0.1/mod.ts\";\n\n// ---------- Env ----------\nconst TG_TOKEN = Deno.env.get(\"TELEGRAM_BOT_TOKEN\")!;\nconst SUPABASE_URL = Deno.env.get(\"SUPABASE_URL\")!;\nconst SUPABASE_KEY = Deno.env.get(\"SUPABASE_ANON_KEY\")!;\nconst ANTHROPIC_KEY = Deno.env.get(\"ANTHROPIC_API_KEY\")!;\nconst GROQ_KEY = Deno.env.get(\"GROQ_API_KEY\")!;\nconst ALLOWED_USER = Deno.env.get(\"ALLOWED_USER_ID\")!;\nconst SHEET_ID = Deno.env.get(\"GOOGLE_SHEET_ID\")!;\nconst WEDDING_SHEET_ID = Deno.env.get(\"WEDDING_SHEET_ID\")!;\nconst SA_JSON = Deno.env.get(\"GOOGLE_SERVICE_ACCOUNT_JSON\")!;\nconst GMAIL_CLIENT_ID = Deno.env.get(\"GMAIL_CLIENT_ID\")!;\nconst GMAIL_CLIENT_SECRET = Deno.env.get(\"GMAIL_CLIENT_SECRET\")!;\nconst GMAIL_REFRESH_TOKEN = Deno.env.get(\"GMAIL_REFRESH_TOKEN\")!;\n\n// ---------- Telegram ----------\nasync function tgReply(chatId: number, text: string) {\n const truncated = text.length > 4000 ? text.slice(0, 3997) + \"...\" : text;\n const attempt = async (useMarkdown: boolean) => {\n const body: any = { chat_id: chatId, text: truncated };\n if (useMarkdown) body.parse_mode = \"Markdown\";\n return await fetch(`https://api.telegram.org/bot${TG_TOKEN}/sendMessage`, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify(body),\n });\n };\n let res = await attempt(true);\n if (!res.ok) res = await attempt(false);\n if (!res.ok) console.error(\"tg send failed:\", await res.text());\n}\n\nasync function tgTyping(chatId: number) {\n // Sends \"typing...\" indicator so user knows we're working\n fetch(`https://api.telegram.org/bot${TG_TOKEN}/sendChatAction`, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ chat_id: chatId, action: \"typing\" }),\n }).catch(() => {});\n}\n\n// ---------- Voice ----------\nasync function downloadVoice(fileId: string): Promise {\n const info =\n await (await fetch(\n `https://api.telegram.org/bot${TG_TOKEN}/getFile?file_id=${fileId}`,\n )).json();\n return await (await fetch(\n `https://api.telegram.org/file/bot${TG_TOKEN}/${info.result.file_path}`,\n )).arrayBuffer();\n}\nasync function transcribe(audio: ArrayBuffer): Promise {\n const form = new FormData();\n form.append(\"file\", new Blob([audio], { type: \"audio/ogg\" }), \"voice.ogg\");\n form.append(\"model\", \"whisper-large-v3\");\n const res = await fetch(\n \"https://api.groq.com/openai/v1/audio/transcriptions\",\n {\n method: \"POST\",\n headers: { Authorization: `Bearer ${GROQ_KEY}` },\n body: form,\n },\n );\n if (!res.ok) throw new Error(`groq ${res.status}`);\n return ((await res.json()).text || \"\").trim();\n}\n\n// ---------- Google auth ----------\nlet cachedToken: { token: string; expiresAt: number } | null = null;\nasync function getGoogleToken(): Promise {\n if (cachedToken && cachedToken.expiresAt > Date.now() + 60_000) {\n return cachedToken.token;\n }\n const sa = JSON.parse(SA_JSON);\n const pem = sa.private_key.replace(/-----BEGIN PRIVATE KEY-----/, \"\").replace(\n /-----END PRIVATE KEY-----/,\n \"\",\n ).replace(/\\s/g, \"\");\n const binaryDer = Uint8Array.from(atob(pem), (c) => c.charCodeAt(0));\n const cryptoKey = await crypto.subtle.importKey(\n \"pkcs8\",\n binaryDer.buffer,\n { name: \"RSASSA-PKCS1-v1_5\", hash: \"SHA-256\" },\n false,\n [\"sign\"],\n );\n const jwt = await createJWT(\n { alg: \"RS256\", typ: \"JWT\" },\n {\n iss: sa.client_email,\n scope: \"https://www.googleapis.com/auth/spreadsheets\",\n aud: \"https://oauth2.googleapis.com/token\",\n exp: getNumericDate(3600),\n iat: getNumericDate(0),\n },\n cryptoKey,\n );\n const res = await fetch(\"https://oauth2.googleapis.com/token\", {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/x-www-form-urlencoded\" },\n body:\n `grant_type=urn:ietf:params:oauth:grant-type:jwt-bearer&assertion=${jwt}`,\n });\n if (!res.ok) throw new Error(`google auth: ${await res.text()}`);\n const data = await res.json();\n cachedToken = {\n token: data.access_token,\n expiresAt: Date.now() + data.expires_in * 1000,\n };\n return data.access_token;\n}\n\n// ---------- Sheets (with caching, multi-sheet) ----------\nconst sheetCache = new Map();\nconst CACHE_TTL_MS = 5 * 60_000;\n\nasync function readRange(\n range: string,\n useCache = false,\n sheetId = SHEET_ID,\n): Promise {\n const cacheKey = `${sheetId}:${range}`;\n if (useCache) {\n const cached = sheetCache.get(cacheKey);\n if (cached && cached.expiresAt > Date.now()) return cached.data;\n }\n const token = await getGoogleToken();\n const res = await fetch(\n `https://sheets.googleapis.com/v4/spreadsheets/${sheetId}/values/${\n encodeURIComponent(range)\n }`,\n { headers: { Authorization: `Bearer ${token}` } },\n );\n if (!res.ok) {\n throw new Error(`sheets read ${res.status}: ${await res.text()}`);\n }\n const data = (await res.json()).values || [];\n if (useCache) {\n sheetCache.set(cacheKey, { data, expiresAt: Date.now() + CACHE_TTL_MS });\n }\n return data;\n}\n\nasync function appendRow(sheetId: string, range: string, values: any[]) {\n const token = await getGoogleToken();\n const res = await fetch(\n `https://sheets.googleapis.com/v4/spreadsheets/${sheetId}/values/${\n encodeURIComponent(range)\n }:append?valueInputOption=USER_ENTERED&insertDataOption=INSERT_ROWS`,\n {\n method: \"POST\",\n headers: {\n Authorization: `Bearer ${token}`,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({ values: [values] }),\n },\n );\n if (!res.ok) throw new Error(`sheets append: ${await res.text()}`);\n // Invalidate cache for this sheet\n for (const k of sheetCache.keys()) {\n if (k.startsWith(`${sheetId}:`)) sheetCache.delete(k);\n }\n return await res.json();\n}\n\nasync function updateRow(sheetId: string, range: string, values: any[]) {\n const token = await getGoogleToken();\n const res = await fetch(\n `https://sheets.googleapis.com/v4/spreadsheets/${sheetId}/values/${\n encodeURIComponent(range)\n }?valueInputOption=USER_ENTERED`,\n {\n method: \"PUT\",\n headers: {\n Authorization: `Bearer ${token}`,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({ values: [values] }),\n },\n );\n if (!res.ok) throw new Error(`sheets update: ${await res.text()}`);\n for (const k of sheetCache.keys()) {\n if (k.startsWith(`${sheetId}:`)) sheetCache.delete(k);\n }\n return await res.json();\n}\n\nasync function appendRun(values: any[]) {\n return await appendRow(SHEET_ID, \"Bot Log!A:I\", values);\n}\n\n// Get the numeric sheet ID (gid) for a tab name — required for deleteDimension/batchUpdate\nasync function getSheetGid(\n spreadsheetId: string,\n tabName: string,\n): Promise {\n const token = await getGoogleToken();\n const res = await fetch(\n `https://sheets.googleapis.com/v4/spreadsheets/${spreadsheetId}?fields=sheets.properties`,\n { headers: { Authorization: `Bearer ${token}` } },\n );\n if (!res.ok) throw new Error(`sheets metadata: ${await res.text()}`);\n const data = await res.json();\n const sheet = data.sheets.find((s: any) => s.properties.title === tabName);\n if (!sheet) throw new Error(`Tab \"${tabName}\" not found`);\n return sheet.properties.sheetId;\n}\n\n// Delete a single row (0-indexed). Note: Google Sheets API rows are 0-indexed for delete operations.\nasync function deleteSheetRow(\n spreadsheetId: string,\n tabName: string,\n rowIndex: number,\n) {\n const token = await getGoogleToken();\n const gid = await getSheetGid(spreadsheetId, tabName);\n const res = await fetch(\n `https://sheets.googleapis.com/v4/spreadsheets/${spreadsheetId}:batchUpdate`,\n {\n method: \"POST\",\n headers: {\n Authorization: `Bearer ${token}`,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({\n requests: [{\n deleteDimension: {\n range: {\n sheetId: gid,\n dimension: \"ROWS\",\n startIndex: rowIndex,\n endIndex: rowIndex + 1,\n },\n },\n }],\n }),\n },\n );\n if (!res.ok) throw new Error(`sheets delete: ${await res.text()}`);\n // Invalidate cache\n for (const k of sheetCache.keys()) {\n if (k.startsWith(`${spreadsheetId}:`)) sheetCache.delete(k);\n }\n return await res.json();\n}\n\n// Delete all rows below the header (row 1). Equivalent to \"clear data\".\nasync function clearSheetData(\n spreadsheetId: string,\n tabName: string,\n): Promise {\n const token = await getGoogleToken();\n const gid = await getSheetGid(spreadsheetId, tabName);\n // First get current row count\n const data = await readRange(`${tabName}!A:A`, false, spreadsheetId);\n const rowCount = data.length;\n if (rowCount <= 1) return 0; // only header or empty\n const res = await fetch(\n `https://sheets.googleapis.com/v4/spreadsheets/${spreadsheetId}:batchUpdate`,\n {\n method: \"POST\",\n headers: {\n Authorization: `Bearer ${token}`,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({\n requests: [{\n deleteDimension: {\n range: {\n sheetId: gid,\n dimension: \"ROWS\",\n startIndex: 1, // keep header (row 0)\n endIndex: rowCount,\n },\n },\n }],\n }),\n },\n );\n if (!res.ok) throw new Error(`sheets clear: ${await res.text()}`);\n for (const k of sheetCache.keys()) {\n if (k.startsWith(`${spreadsheetId}:`)) sheetCache.delete(k);\n }\n return rowCount - 1; // number of data rows deleted\n}\n\n// ---------- Gmail auth (user OAuth refresh token) ----------\nlet cachedGmailToken: { token: string; expiresAt: number } | null = null;\nasync function getGmailToken(): Promise {\n if (cachedGmailToken && cachedGmailToken.expiresAt > Date.now() + 60_000) {\n return cachedGmailToken.token;\n }\n const res = await fetch(\"https://oauth2.googleapis.com/token\", {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/x-www-form-urlencoded\" },\n body: new URLSearchParams({\n client_id: GMAIL_CLIENT_ID,\n client_secret: GMAIL_CLIENT_SECRET,\n refresh_token: GMAIL_REFRESH_TOKEN,\n grant_type: \"refresh_token\",\n }).toString(),\n });\n if (!res.ok) throw new Error(`gmail auth: ${await res.text()}`);\n const data = await res.json();\n cachedGmailToken = {\n token: data.access_token,\n expiresAt: Date.now() + data.expires_in * 1000,\n };\n return data.access_token;\n}\n\n// ---------- Gmail helpers ----------\nfunction decodeBase64Url(str: string): string {\n const b64 = str.replace(/-/g, \"+\").replace(/_/g, \"/\");\n const padded = b64 + \"=\".repeat((4 - b64.length % 4) % 4);\n try {\n return new TextDecoder(\"utf-8\").decode(\n Uint8Array.from(atob(padded), (c) => c.charCodeAt(0)),\n );\n } catch {\n return \"\";\n }\n}\nfunction extractEmailBody(payload: any): string {\n if (!payload) return \"\";\n if (payload.body?.data) return decodeBase64Url(payload.body.data);\n if (payload.parts) {\n // Prefer text/plain, fall back to text/html stripped\n const plain = payload.parts.find((p: any) => p.mimeType === \"text/plain\");\n if (plain?.body?.data) return decodeBase64Url(plain.body.data);\n const html = payload.parts.find((p: any) => p.mimeType === \"text/html\");\n if (html?.body?.data) {\n return decodeBase64Url(html.body.data).replace(/<[^>]+>/g, \" \").replace(\n /\\s+/g,\n \" \",\n );\n }\n // Recurse into multipart/* parts\n for (const part of payload.parts) {\n const nested = extractEmailBody(part);\n if (nested) return nested;\n }\n }\n return \"\";\n}\nfunction getHeader(headers: any[], name: string): string {\n return headers?.find((h: any) => h.name.toLowerCase() === name.toLowerCase())\n ?.value || \"\";\n}\n\nasync function gmailSearch(query: string, maxResults = 10): Promise {\n const token = await getGmailToken();\n const res = await fetch(\n `https://gmail.googleapis.com/gmail/v1/users/me/messages?q=${\n encodeURIComponent(query)\n }&maxResults=${maxResults}`,\n { headers: { Authorization: `Bearer ${token}` } },\n );\n if (!res.ok) throw new Error(`gmail search: ${await res.text()}`);\n const data = await res.json();\n if (!data.messages) return [];\n // Fetch metadata for each message in parallel\n const details = await Promise.all(\n data.messages.map(async (m: any) => {\n const r = await fetch(\n `https://gmail.googleapis.com/gmail/v1/users/me/messages/${m.id}?format=metadata&metadataHeaders=From&metadataHeaders=To&metadataHeaders=Subject&metadataHeaders=Date`,\n { headers: { Authorization: `Bearer ${token}` } },\n );\n if (!r.ok) return null;\n const msg = await r.json();\n return {\n id: msg.id,\n threadId: msg.threadId,\n snippet: msg.snippet,\n from: getHeader(msg.payload.headers, \"From\"),\n to: getHeader(msg.payload.headers, \"To\"),\n subject: getHeader(msg.payload.headers, \"Subject\"),\n date: getHeader(msg.payload.headers, \"Date\"),\n };\n }),\n );\n return details.filter(Boolean);\n}\n\nasync function gmailReadMessage(messageId: string): Promise {\n const token = await getGmailToken();\n const res = await fetch(\n `https://gmail.googleapis.com/gmail/v1/users/me/messages/${messageId}?format=full`,\n { headers: { Authorization: `Bearer ${token}` } },\n );\n if (!res.ok) throw new Error(`gmail read: ${await res.text()}`);\n const msg = await res.json();\n return {\n id: msg.id,\n threadId: msg.threadId,\n from: getHeader(msg.payload.headers, \"From\"),\n to: getHeader(msg.payload.headers, \"To\"),\n subject: getHeader(msg.payload.headers, \"Subject\"),\n date: getHeader(msg.payload.headers, \"Date\"),\n body: extractEmailBody(msg.payload).slice(0, 5000), // cap at 5k chars to avoid context bloat\n };\n}\n\nasync function gmailReadThread(threadId: string): Promise {\n const token = await getGmailToken();\n const res = await fetch(\n `https://gmail.googleapis.com/gmail/v1/users/me/threads/${threadId}?format=full`,\n { headers: { Authorization: `Bearer ${token}` } },\n );\n if (!res.ok) throw new Error(`gmail thread: ${await res.text()}`);\n const data = await res.json();\n return data.messages.map((msg: any) => ({\n id: msg.id,\n from: getHeader(msg.payload.headers, \"From\"),\n to: getHeader(msg.payload.headers, \"To\"),\n subject: getHeader(msg.payload.headers, \"Subject\"),\n date: getHeader(msg.payload.headers, \"Date\"),\n body: extractEmailBody(msg.payload).slice(0, 3000),\n }));\n}\n\nasync function gmailCreateDraft(\n to: string,\n subject: string,\n body: string,\n threadId?: string,\n): Promise {\n const token = await getGmailToken();\n // Build RFC 2822 message\n const messageLines = [\n `To: ${to}`,\n `Subject: ${subject}`,\n `Content-Type: text/plain; charset=\"UTF-8\"`,\n \"\",\n body,\n ];\n const rawMessage = messageLines.join(\"\\r\\n\");\n // Base64url encode\n const encoded = btoa(rawMessage).replace(/\\+/g, \"-\").replace(/\\//g, \"_\")\n .replace(/=+$/, \"\");\n const draftBody: any = { message: { raw: encoded } };\n if (threadId) draftBody.message.threadId = threadId;\n const res = await fetch(\n \"https://gmail.googleapis.com/gmail/v1/users/me/drafts\",\n {\n method: \"POST\",\n headers: {\n Authorization: `Bearer ${token}`,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify(draftBody),\n },\n );\n if (!res.ok) throw new Error(`gmail draft: ${await res.text()}`);\n return await res.json();\n}\n\n// ---------- Week math ----------\nconst RACE_DAY = new Date(\"2026-08-29\");\nconst WEEK_1_START = new Date(\"2026-03-29\");\nfunction weekForDate(d: Date): number | null {\n if (d < WEEK_1_START || d > RACE_DAY) return null;\n return Math.floor((d.getTime() - WEEK_1_START.getTime()) / (7 * 86400_000)) +\n 1;\n}\n\n// ---------- Supabase (todos) ----------\nasync function sbFetch(path: string, opts: any = {}) {\n const res = await fetch(`${SUPABASE_URL}/rest/v1/${path}`, {\n ...opts,\n headers: {\n apikey: SUPABASE_KEY,\n Authorization: `Bearer ${SUPABASE_KEY}`,\n \"Content-Type\": \"application/json\",\n Prefer: \"return=representation\",\n ...(opts.headers || {}),\n },\n });\n if (!res.ok) throw new Error(`supabase ${res.status}: ${await res.text()}`);\n if (opts.method === \"DELETE\" || res.status === 204) return null;\n const text = await res.text();\n return text ? JSON.parse(text) : null;\n}\n\n// ---------- Pace helpers ----------\nfunction timeToSeconds(t: string): number {\n const parts = t.split(\":\").map(Number);\n if (parts.length === 3) return parts[0] * 3600 + parts[1] * 60 + parts[2];\n if (parts.length === 2) return parts[0] * 60 + parts[1];\n return 0;\n}\nfunction secondsToPace(secs: number, miles: number): string {\n if (!miles || miles <= 0) return \"\";\n const paceSec = Math.round(secs / miles);\n const m = Math.floor(paceSec / 60);\n const s = paceSec % 60;\n return `${m}:${s.toString().padStart(2, \"0\")}`;\n}\n\n// ---------- Pending confirmation cache ----------\nconst pendingConfirms = new Map<\n number,\n { kind: string; data: any; expires: number }\n>();\nfunction setPending(chatId: number, kind: string, data: any) {\n pendingConfirms.set(chatId, { kind, data, expires: Date.now() + 5 * 60_000 });\n}\nfunction getPending(chatId: number) {\n const p = pendingConfirms.get(chatId);\n if (!p || p.expires < Date.now()) {\n pendingConfirms.delete(chatId);\n return null;\n }\n return p;\n}\n\n// ============================================================\n// TOOL DEFINITIONS\n// ============================================================\nconst TOOLS = [\n // ----- Hood to Coast -----\n {\n name: \"get_todays_plan\",\n description:\n \"Read today's planned workout from the Hood to Coast training plan. Use this when the user asks what they should run today, what's scheduled, or before logging a run to compare actual vs planned.\",\n input_schema: { type: \"object\", properties: {} },\n },\n {\n name: \"get_week_progress\",\n description:\n \"Get the user's logged miles vs planned miles for a specific training week (1-22). Use this when the user asks how they're tracking, what's left, or before logging a run to give weekly context.\",\n input_schema: {\n type: \"object\",\n properties: {\n week: { type: \"number\", description: \"Training week number 1-22\" },\n },\n required: [\"week\"],\n },\n },\n {\n name: \"get_recent_runs\",\n description:\n \"Get the user's most recent logged runs/workouts (default 5). Use to spot trends, check feel scores, see what they've been doing.\",\n input_schema: {\n type: \"object\",\n properties: {\n limit: {\n type: \"number\",\n description: \"How many recent entries (default 5)\",\n },\n },\n },\n },\n {\n name: \"get_guide_info\",\n description:\n \"Read the Hood to Coast guide tab — contains pace targets, non-negotiables (e.g., rest if hurt 2+ days), strength routine, etc. Use when the user asks training questions.\",\n input_schema: { type: \"object\", properties: {} },\n },\n {\n name: \"log_run\",\n description:\n \"Write a new run/workout entry to the Bot Log sheet. ONLY call this AFTER the user has explicitly confirmed (said yes/confirm/log it). To propose a run for confirmation, just describe it in your reply and ASK the user to confirm — do not call this tool until they say yes.\",\n input_schema: {\n type: \"object\",\n properties: {\n miles: { type: \"number\" },\n time: { type: \"string\", description: \"Format h:mm:ss (e.g. 0:39:21)\" },\n feel: { type: \"number\", description: \"1-10 effort/quality rating\" },\n workout: {\n type: \"string\",\n description: \"Run, Strength, Pilates, Brick, etc\",\n },\n notes: { type: \"string\" },\n date: {\n type: \"string\",\n description: \"ISO date YYYY-MM-DD; defaults to today if omitted\",\n },\n },\n required: [\"workout\"],\n },\n },\n\n // ----- Todos -----\n {\n name: \"list_todos\",\n description:\n \"List the user's open todos. Optionally filter by category (inbox, school, career, personal).\",\n input_schema: {\n type: \"object\",\n properties: {\n category: {\n type: \"string\",\n enum: [\"inbox\", \"school\", \"career\", \"personal\", \"all\"],\n },\n },\n },\n },\n {\n name: \"add_todo\",\n description:\n \"Add a new todo. Defaults to inbox; user can specify category. Use for any actionable thing the user wants to remember to do.\",\n input_schema: {\n type: \"object\",\n properties: {\n task: { type: \"string\" },\n category: {\n type: \"string\",\n enum: [\"inbox\", \"school\", \"career\", \"personal\"],\n },\n },\n required: [\"task\"],\n },\n },\n {\n name: \"complete_todo\",\n description:\n \"Mark a todo as done. Pass the task description to fuzzy-match.\",\n input_schema: {\n type: \"object\",\n properties: {\n task_description: {\n type: \"string\",\n description:\n \"Description of the todo to complete; will be matched semantically\",\n },\n },\n required: [\"task_description\"],\n },\n },\n\n // ----- General -----\n {\n name: \"web_search\",\n description:\n \"Search the web for current information (weather, news, recent events, etc). Use when the user asks about anything time-sensitive or factual you need to verify.\",\n input_schema: {\n type: \"object\",\n properties: { query: { type: \"string\" } },\n required: [\"query\"],\n },\n },\n\n // ----- Daily briefing on demand -----\n {\n name: \"get_daily_briefing\",\n description:\n \"Generate the user's daily briefing on demand — same content as her scheduled morning briefing. Use this when she explicitly asks for a briefing, news roundup, what's happening today, or 'catch me up'. This takes ~10-15 seconds because it does live web research.\",\n input_schema: { type: \"object\", properties: {} },\n },\n\n // ----- Wedding: vendors -----\n {\n name: \"list_vendors\",\n description:\n \"List wedding vendors with their status, costs, and notes. Optionally filter by category (florist, DJ, venue, photographer, etc) or status (researching, quoted, booked, etc).\",\n input_schema: {\n type: \"object\",\n properties: {\n category: {\n type: \"string\",\n description: \"Filter by vendor category (optional)\",\n },\n status: { type: \"string\", description: \"Filter by status (optional)\" },\n },\n },\n },\n {\n name: \"add_vendor\",\n description:\n \"Add a new wedding vendor to the Vendors tab. Use when the user mentions researching, contacting, or working with a new vendor.\",\n input_schema: {\n type: \"object\",\n properties: {\n category: {\n type: \"string\",\n description: \"florist, DJ, venue, photographer, caterer, etc\",\n },\n name: { type: \"string\", description: \"Business name\" },\n contact_name: { type: \"string\" },\n email: { type: \"string\" },\n phone: { type: \"string\" },\n status: {\n type: \"string\",\n description: \"researching, contacted, quoted, booked, declined\",\n },\n quote_amount: { type: \"number\" },\n deposit_paid: { type: \"number\" },\n balance_due: { type: \"number\" },\n balance_due_date: { type: \"string\", description: \"YYYY-MM-DD\" },\n next_action: { type: \"string\" },\n notes: { type: \"string\" },\n },\n required: [\"category\", \"name\"],\n },\n },\n {\n name: \"update_vendor\",\n description:\n \"Update fields on an existing vendor row. Pass the vendor's id (e.g. V001) or unique name to identify it, plus any fields to change.\",\n input_schema: {\n type: \"object\",\n properties: {\n vendor_id_or_name: {\n type: \"string\",\n description: \"Vendor ID like V001 or business name like 'Bloom & Co'\",\n },\n status: { type: \"string\" },\n quote_amount: { type: \"number\" },\n deposit_paid: { type: \"number\" },\n balance_due: { type: \"number\" },\n balance_due_date: { type: \"string\" },\n last_contact_date: {\n type: \"string\",\n description:\n \"YYYY-MM-DD; defaults to today if not provided and the user just had contact\",\n },\n next_action: { type: \"string\" },\n notes: {\n type: \"string\",\n description:\n \"If updating notes, prepend new info to existing notes; don't overwrite blindly\",\n },\n },\n required: [\"vendor_id_or_name\"],\n },\n },\n\n // ----- Wedding: guests -----\n {\n name: \"list_guests\",\n description:\n \"List wedding guests. Filter by RSVP status (pending, yes, no, maybe), side (Neesha, Tony), tier (A, B, C), or dietary restriction.\",\n input_schema: {\n type: \"object\",\n properties: {\n rsvp_status: { type: \"string\" },\n side: { type: \"string\" },\n tier: { type: \"string\" },\n },\n },\n },\n {\n name: \"add_guest\",\n description: \"Add a new guest to the wedding guest list.\",\n input_schema: {\n type: \"object\",\n properties: {\n name: { type: \"string\" },\n side: { type: \"string\", description: \"Neesha or Tony\" },\n relationship: {\n type: \"string\",\n description: \"friend, family, work, etc\",\n },\n tier: {\n type: \"string\",\n description: \"A (must invite), B (next round), C (if space)\",\n },\n email: { type: \"string\" },\n phone: { type: \"string\" },\n plus_one_allowed: { type: \"boolean\" },\n plus_one_name: { type: \"string\" },\n notes: { type: \"string\" },\n },\n required: [\"name\"],\n },\n },\n {\n name: \"update_rsvp\",\n description: \"Update a guest's RSVP status when they respond.\",\n input_schema: {\n type: \"object\",\n properties: {\n guest_id_or_name: {\n type: \"string\",\n description: \"Guest ID like G001 or full name\",\n },\n rsvp_status: { type: \"string\", description: \"yes, no, maybe, pending\" },\n plus_one_name: {\n type: \"string\",\n description: \"If they're bringing one — name of plus one\",\n },\n dietary: { type: \"string\" },\n song_request: { type: \"string\" },\n notes: { type: \"string\" },\n },\n required: [\"guest_id_or_name\", \"rsvp_status\"],\n },\n },\n\n // ----- Wedding: decisions -----\n {\n name: \"log_wedding_decision\",\n description:\n \"Record a major wedding decision in the Decisions tab. Use when the user makes or describes a final choice about the wedding (venue, date, theme, etc).\",\n input_schema: {\n type: \"object\",\n properties: {\n decision: {\n type: \"string\",\n description: \"The decision in one sentence\",\n },\n category: {\n type: \"string\",\n description: \"venue, ceremony, reception, food, etc\",\n },\n notes: { type: \"string\" },\n },\n required: [\"decision\"],\n },\n },\n\n // ----- Wedding: budget summary -----\n {\n name: \"get_wedding_budget_summary\",\n description:\n \"Read the budget tab and vendors to give a quick financial snapshot — total estimated, total quoted, total paid, total remaining.\",\n input_schema: { type: \"object\", properties: {} },\n },\n\n // ----- Gmail -----\n {\n name: \"search_gmail\",\n description:\n \"Search Neesha's Gmail inbox. Use Gmail search syntax (e.g., 'from:florist', 'subject:invoice', 'love and wolves', 'has:attachment vendor'). Returns a list of matching messages with from/subject/date/snippet but NOT full body. Call read_email to get the full body of a specific message.\",\n input_schema: {\n type: \"object\",\n properties: {\n query: { type: \"string\", description: \"Gmail search query\" },\n max_results: {\n type: \"number\",\n description: \"Max messages to return (default 10, max 25)\",\n },\n },\n required: [\"query\"],\n },\n },\n {\n name: \"read_email\",\n description:\n \"Read the full body of a specific email by message ID (from search_gmail results). Returns from, to, subject, date, and full body.\",\n input_schema: {\n type: \"object\",\n properties: { message_id: { type: \"string\" } },\n required: [\"message_id\"],\n },\n },\n {\n name: \"read_email_thread\",\n description:\n \"Read all messages in an email thread by thread ID. Useful when an email has back-and-forth context (negotiations, scheduling).\",\n input_schema: {\n type: \"object\",\n properties: { thread_id: { type: \"string\" } },\n required: [\"thread_id\"],\n },\n },\n {\n name: \"create_email_draft\",\n description:\n \"Create a draft email saved to Neesha's Drafts folder in Gmail. She will review and send manually — this does NOT auto-send. Use when she asks to draft a reply, follow up with a vendor, etc. If replying to an existing thread, pass thread_id to keep it in the same thread.\",\n input_schema: {\n type: \"object\",\n properties: {\n to: { type: \"string\", description: \"Recipient email address\" },\n subject: { type: \"string\" },\n body: {\n type: \"string\",\n description:\n \"Plain text email body. Match Neesha's voice: direct, warm, no fluff, no emojis unless she usually uses them.\",\n },\n thread_id: {\n type: \"string\",\n description: \"Optional — Gmail thread ID if this is a reply\",\n },\n },\n required: [\"to\", \"subject\", \"body\"],\n },\n },\n\n // ----- Wedding: delete / clear -----\n {\n name: \"delete_wedding_row\",\n description:\n \"Delete a specific row from a tab in the wedding sheet (Vendors, Guests, Tasks, Decisions, or Budget). CRITICAL: Before calling this tool, you MUST describe what will be deleted and ask the user to confirm. Only call this AFTER the user has explicitly confirmed (yes/confirm/delete it). Never call without confirmation.\",\n input_schema: {\n type: \"object\",\n properties: {\n tab: {\n type: \"string\",\n enum: [\"Vendors\", \"Guests\", \"Tasks\", \"Decisions\", \"Budget\"],\n },\n id_or_name: {\n type: \"string\",\n description:\n \"ID (V001, G001, etc) or unique name/text to find the row to delete\",\n },\n },\n required: [\"tab\", \"id_or_name\"],\n },\n },\n {\n name: \"clear_wedding_tab\",\n description:\n \"Delete ALL data rows from a wedding tab (keeps the header row). Use for clearing dummy/test data. CRITICAL: Always describe exactly which tab and how many rows will be cleared, then wait for explicit user confirmation (yes/confirm). Never call without confirmation. Destructive and cannot be undone except via Google Sheets manual undo (Ctrl+Z) right after.\",\n input_schema: {\n type: \"object\",\n properties: {\n tab: {\n type: \"string\",\n enum: [\"Vendors\", \"Guests\", \"Tasks\", \"Decisions\", \"Budget\"],\n },\n },\n required: [\"tab\"],\n },\n },\n];\n\n// ============================================================\n// TOOL EXECUTORS\n// ============================================================\nasync function executeTool(name: string, input: any): Promise {\n switch (name) {\n case \"get_todays_plan\": {\n const today = new Date();\n const week = weekForDate(today);\n if (!week) {\n return \"Today is outside the training plan window (plan runs Mar 29 - Aug 29, 2026).\";\n }\n const rows = await readRange(`Plan!A${4 + week}:K${4 + week}`, true); // cached\n if (!rows.length) return \"No plan row found.\";\n const row = rows[0];\n const dayIdx = today.getDay();\n const dayName =\n [\n \"Sunday\",\n \"Monday\",\n \"Tuesday\",\n \"Wednesday\",\n \"Thursday\",\n \"Friday\",\n \"Saturday\",\n ][dayIdx];\n const workout = row[3 + dayIdx] || \"Rest\";\n const phase = row[2] || \"\";\n const weekTotal = row[10] || \"0\";\n return JSON.stringify({\n date: today.toDateString(),\n week,\n day: dayName,\n phase,\n todays_workout: workout,\n week_planned_total_mi: weekTotal,\n });\n }\n\n case \"get_week_progress\": {\n const week = input.week;\n // Run these two reads in parallel\n const [logRows, planRow] = await Promise.all([\n readRange(`Bot Log!A5:I1000`),\n readRange(`Plan!A${4 + week}:K${4 + week}`, true), // plan is cached\n ]);\n const logged = logRows.filter((r: any[]) => parseInt(r[1]) === week);\n const totalMiles = logged.reduce(\n (s: number, r: any[]) => s + (parseFloat(r[3]) || 0),\n 0,\n );\n const planTotal = planRow.length ? parseFloat(planRow[0][10] || \"0\") : 0;\n return JSON.stringify({\n week,\n logged_count: logged.length,\n actual_miles: totalMiles.toFixed(1),\n planned_miles: planTotal,\n pct_complete: planTotal > 0\n ? Math.round((totalMiles / planTotal) * 100)\n : 0,\n sessions: logged.map((r: any[]) => ({\n date: r[0],\n workout: r[2],\n miles: r[3],\n time: r[4],\n pace: r[5],\n feel: r[6],\n notes: r[7],\n })),\n });\n }\n\n case \"get_recent_runs\": {\n const limit = input.limit || 5;\n const rows = await readRange(`Bot Log!A5:I1000`);\n const recent = rows.slice(-limit).reverse();\n return JSON.stringify(\n recent.map((r: any[]) => ({\n date: r[0],\n week: r[1],\n workout: r[2],\n miles: r[3],\n time: r[4],\n pace: r[5],\n feel: r[6],\n notes: r[7],\n })),\n );\n }\n\n case \"get_guide_info\": {\n const rows = await readRange(`Guide!A1:B100`, true); // cached\n return rows.map((r: any[]) => `${r[0] || \"\"} ${r[1] || \"\"}`).filter((s) =>\n s.trim()\n ).join(\"\\n\");\n }\n\n case \"log_run\": {\n const date = input.date ? new Date(input.date) : new Date();\n const week = weekForDate(date) || 0;\n const dateStr = `${(date.getMonth() + 1).toString().padStart(2, \"0\")}/${\n date.getDate().toString().padStart(2, \"0\")\n }/${date.getFullYear()}`;\n const miles = input.miles || \"\";\n const time = input.time || \"\";\n let pace = \"\";\n if (miles && time) {\n pace = secondsToPace(timeToSeconds(time), miles);\n }\n const row = [\n dateStr,\n week,\n input.workout,\n miles,\n time,\n pace,\n input.feel || \"\",\n input.notes || \"\",\n \"bot\",\n ];\n await appendRun(row);\n return JSON.stringify({\n success: true,\n logged: { date: dateStr, week, ...input, pace },\n });\n }\n\n case \"list_todos\": {\n const cat = input.category;\n const todos = await sbFetch(\n \"todos?status=eq.open&order=sort_order.asc,created_at.asc\",\n );\n const filtered = !cat || cat === \"all\"\n ? todos\n : todos.filter((t: any) => (t.category || \"inbox\") === cat);\n return JSON.stringify(\n filtered.map((t: any) => ({\n id: t.id,\n task: t.task,\n category: t.category || \"inbox\",\n starred: t.starred,\n })),\n );\n }\n\n case \"add_todo\": {\n const result = await sbFetch(\"todos\", {\n method: \"POST\",\n body: JSON.stringify({\n task: input.task,\n category: input.category || \"inbox\",\n priority: 3,\n sort_order: Date.now(),\n }),\n });\n return JSON.stringify({ success: true, added: result?.[0] });\n }\n\n case \"complete_todo\": {\n const todos = await sbFetch(\"todos?status=eq.open\");\n const desc = input.task_description.toLowerCase();\n const match = todos.find((t: any) =>\n t.task.toLowerCase().includes(desc) ||\n desc.includes(t.task.toLowerCase())\n );\n if (!match) {\n return JSON.stringify({\n success: false,\n reason: \"no matching todo found\",\n });\n }\n await sbFetch(`todos?id=eq.${match.id}`, {\n method: \"PATCH\",\n body: JSON.stringify({\n status: \"done\",\n completed_at: new Date().toISOString(),\n }),\n });\n return JSON.stringify({ success: true, completed: match.task });\n }\n\n case \"web_search\": {\n // Use Claude with web_search tool for the actual search\n const res = await fetch(\"https://api.anthropic.com/v1/messages\", {\n method: \"POST\",\n headers: {\n \"x-api-key\": ANTHROPIC_KEY,\n \"anthropic-version\": \"2023-06-01\",\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({\n model: \"claude-haiku-4-5-20251001\",\n max_tokens: 800,\n messages: [{\n role: \"user\",\n content:\n `Search the web for: ${input.query}. Reply with a concise factual answer.`,\n }],\n tools: [{ type: \"web_search_20250305\", name: \"web_search\" }],\n }),\n });\n if (!res.ok) return `Search failed: ${res.status}`;\n const json = await res.json();\n return json.content.filter((b: any) => b.type === \"text\").map((b: any) =>\n b.text\n ).join(\"\\n\").trim();\n }\n\n case \"get_daily_briefing\": {\n // Same prompt as the scheduled briefing val, run on demand\n const today = new Date().toLocaleDateString(\"en-US\", {\n weekday: \"long\",\n month: \"long\",\n day: \"numeric\",\n year: \"numeric\",\n timeZone: \"America/Chicago\",\n });\n const briefingPrompt =\n `You are Neesha's chief of staff. Write her on-demand briefing for ${today}.\n\nShe cares about:\n- AI/tech funding rounds (Seed-Series C) at AI companies, especially from Sequoia, a16z, Greylock, Benchmark, Founders Fund, Iconiq, Lightspeed, Index, Accel, Khosla, Greenoaks\n- Tech acquisitions, especially AI/agents/enterprise SaaS\n- Major releases or news from Anthropic, OpenAI, Google DeepMind\n- Public statements/essays/podcasts from Dario Amodei, Bret Taylor, Marc Benioff, Sam Altman\n- Customer wins or strategic moves from agent companies (Sierra, Decagon, Cresta, Adept, Cognition, Harvey)\n- Geopolitical: Middle East (Iran, Hormuz), US-China tech relations, major energy/election news\n\nSkip: generic AI thinkpieces, daily stock fluctuations, celebrity/sports/entertainment, repeat coverage, minor product features.\n\nINSTRUCTIONS:\n- Use web search to find what's actually happened in the past 24 hours.\n- Filter ruthlessly. 4-6 items max. Better to surface 3 great items than 8 mediocre ones.\n- 1-2 sentences per item. Sharp, factual, no hype.\n- Use *bold* for category headers. Plain text otherwise. Telegram-friendly.\n- If almost nothing happened, say so directly. Don't pad.\n\nFormat:\n*${today}*\n\n*AI / TECH*\n- Item 1\n- Item 2\n\n*GEOPOLITICAL*\n- Item 1\n\nKeep total under 250 words.`;\n\n const res = await fetch(\"https://api.anthropic.com/v1/messages\", {\n method: \"POST\",\n headers: {\n \"x-api-key\": ANTHROPIC_KEY,\n \"anthropic-version\": \"2023-06-01\",\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({\n model: \"claude-opus-4-7\", // Opus for better synthesis on this one\n max_tokens: 2500,\n messages: [{ role: \"user\", content: briefingPrompt }],\n tools: [{ type: \"web_search_20250305\", name: \"web_search\" }],\n }),\n });\n if (!res.ok) return `Briefing failed: ${res.status}`;\n const json = await res.json();\n const text = json.content.filter((b: any) => b.type === \"text\").map((\n b: any,\n ) => b.text).join(\"\\n\").trim();\n return text;\n }\n\n // ===== Wedding: vendors =====\n case \"list_vendors\": {\n const rows = await readRange(\"Vendors!A:O\", true, WEDDING_SHEET_ID);\n if (rows.length < 2) return JSON.stringify({ vendors: [] });\n const headers = rows[0];\n const vendors = rows.slice(1)\n .filter((r) => r[0]) // skip empty rows\n .map((r) =>\n Object.fromEntries(\n headers.map((h: string, i: number) => [h, r[i] || \"\"]),\n )\n );\n let filtered = vendors;\n if (input.category) {\n const cat = input.category.toLowerCase();\n filtered = filtered.filter((v: any) =>\n (v.category || \"\").toLowerCase().includes(cat)\n );\n }\n if (input.status) {\n const st = input.status.toLowerCase();\n filtered = filtered.filter((v: any) =>\n (v.status || \"\").toLowerCase().includes(st)\n );\n }\n return JSON.stringify({ vendors: filtered });\n }\n\n case \"add_vendor\": {\n // Find next vendor ID\n const rows = await readRange(\"Vendors!A:A\", false, WEDDING_SHEET_ID);\n const existingIds = rows.slice(1).map((r) => r[0] || \"\").filter((s) =>\n s.startsWith(\"V\")\n );\n const maxNum = existingIds.length\n ? Math.max(...existingIds.map((id) => parseInt(id.slice(1)) || 0))\n : 0;\n const newId = `V${(maxNum + 1).toString().padStart(3, \"0\")}`;\n // Order from sheet: id, category, name, contact_name, email, phone, status, quote_amount, deposit_paid, balance_due, balance_due_date, contract_link, last_contact_date, next_action, notes\n const today = new Date().toISOString().slice(0, 10);\n const row = [\n newId,\n input.category,\n input.name,\n input.contact_name || \"\",\n input.email || \"\",\n input.phone || \"\",\n input.status || \"researching\",\n input.quote_amount ?? \"\",\n input.deposit_paid ?? \"\",\n input.balance_due ?? \"\",\n input.balance_due_date || \"\",\n \"\", // contract_link\n today,\n input.next_action || \"\",\n input.notes || \"\",\n ];\n await appendRow(WEDDING_SHEET_ID, \"Vendors!A:O\", row);\n return JSON.stringify({ success: true, id: newId, vendor: input.name });\n }\n\n case \"update_vendor\": {\n const rows = await readRange(\"Vendors!A:O\", false, WEDDING_SHEET_ID);\n if (rows.length < 2) {\n return JSON.stringify({ success: false, reason: \"no vendors\" });\n }\n const idQuery = (input.vendor_id_or_name || \"\").toLowerCase();\n const headers = rows[0];\n let rowIdx = -1;\n for (let i = 1; i < rows.length; i++) {\n const id = (rows[i][0] || \"\").toLowerCase();\n const name = (rows[i][2] || \"\").toLowerCase();\n if (id === idQuery || name === idQuery || name.includes(idQuery)) {\n rowIdx = i;\n break;\n }\n }\n if (rowIdx === -1) {\n return JSON.stringify({\n success: false,\n reason: `no vendor matched \"${input.vendor_id_or_name}\"`,\n });\n }\n const current = rows[rowIdx];\n // Map field names to column indices\n const fieldMap: Record = {\n status: 6,\n quote_amount: 7,\n deposit_paid: 8,\n balance_due: 9,\n balance_due_date: 10,\n last_contact_date: 12,\n next_action: 13,\n notes: 14,\n };\n const updated = [...current];\n for (const [field, value] of Object.entries(input)) {\n if (field === \"vendor_id_or_name\") continue;\n if (field in fieldMap) {\n if (field === \"notes\" && current[14] && value) {\n // Prepend new note to existing notes with date\n const today = new Date().toISOString().slice(0, 10);\n updated[14] = `${today}: ${value} | ${current[14]}`;\n } else {\n updated[fieldMap[field]] = value as any;\n }\n }\n }\n // If user passed last_contact_date implicitly (because they just had contact), set it\n if (\n !input.last_contact_date &&\n (input.notes || input.next_action || input.status)\n ) {\n updated[12] = new Date().toISOString().slice(0, 10);\n }\n const sheetRow = rowIdx + 1; // 1-indexed for sheets\n await updateRow(\n WEDDING_SHEET_ID,\n `Vendors!A${sheetRow}:O${sheetRow}`,\n updated,\n );\n return JSON.stringify({ success: true, updated_vendor: current[2] });\n }\n\n // ===== Wedding: guests =====\n case \"list_guests\": {\n const rows = await readRange(\"Guests!A:R\", true, WEDDING_SHEET_ID);\n if (rows.length < 2) return JSON.stringify({ guests: [], count: 0 });\n const headers = rows[0];\n const guests = rows.slice(1)\n .filter((r) => r[0])\n .map((r) =>\n Object.fromEntries(\n headers.map((h: string, i: number) => [h, r[i] || \"\"]),\n )\n );\n let filtered = guests;\n if (input.rsvp_status) {\n const s = input.rsvp_status.toLowerCase();\n filtered = filtered.filter((g: any) =>\n (g.rsvp_status || \"\").toLowerCase() === s\n );\n }\n if (input.side) {\n const s = input.side.toLowerCase();\n filtered = filtered.filter((g: any) =>\n (g.side || \"\").toLowerCase() === s\n );\n }\n if (input.tier) {\n filtered = filtered.filter((g: any) => g.tier === input.tier);\n }\n return JSON.stringify({\n guests: filtered,\n count: filtered.length,\n total_in_list: guests.length,\n });\n }\n\n case \"add_guest\": {\n const rows = await readRange(\"Guests!A:A\", false, WEDDING_SHEET_ID);\n const existingIds = rows.slice(1).map((r) => r[0] || \"\").filter((s) =>\n s.startsWith(\"G\")\n );\n const maxNum = existingIds.length\n ? Math.max(...existingIds.map((id) => parseInt(id.slice(1)) || 0))\n : 0;\n const newId = `G${(maxNum + 1).toString().padStart(3, \"0\")}`;\n // Order: id, name, side, relationship, tier, email, phone, address, plus_one_allowed, plus_one_name, save_the_date_sent, invite_sent, rsvp_status, rsvp_date, dietary, song_request, table, notes\n const row = [\n newId,\n input.name,\n input.side || \"\",\n input.relationship || \"\",\n input.tier || \"B\",\n input.email || \"\",\n input.phone || \"\",\n \"\", // address\n input.plus_one_allowed ? \"TRUE\" : \"FALSE\",\n input.plus_one_name || \"\",\n \"FALSE\", // save_the_date_sent\n \"FALSE\", // invite_sent\n \"pending\", // rsvp_status\n \"\", // rsvp_date\n \"\", // dietary\n \"\", // song_request\n \"\", // table\n input.notes || \"\",\n ];\n await appendRow(WEDDING_SHEET_ID, \"Guests!A:R\", row);\n return JSON.stringify({ success: true, id: newId, guest: input.name });\n }\n\n case \"update_rsvp\": {\n const rows = await readRange(\"Guests!A:R\", false, WEDDING_SHEET_ID);\n if (rows.length < 2) {\n return JSON.stringify({ success: false, reason: \"no guests\" });\n }\n const query = (input.guest_id_or_name || \"\").toLowerCase();\n let rowIdx = -1;\n for (let i = 1; i < rows.length; i++) {\n const id = (rows[i][0] || \"\").toLowerCase();\n const name = (rows[i][1] || \"\").toLowerCase();\n if (id === query || name === query || name.includes(query)) {\n rowIdx = i;\n break;\n }\n }\n if (rowIdx === -1) {\n return JSON.stringify({\n success: false,\n reason: `no guest matched \"${input.guest_id_or_name}\"`,\n });\n }\n const updated = [...rows[rowIdx]];\n const today = new Date().toISOString().slice(0, 10);\n updated[12] = input.rsvp_status; // rsvp_status\n updated[13] = today; // rsvp_date\n if (input.plus_one_name) updated[9] = input.plus_one_name;\n if (input.dietary) updated[14] = input.dietary;\n if (input.song_request) updated[15] = input.song_request;\n if (input.notes) {\n const existing = updated[17] || \"\";\n updated[17] = existing\n ? `${today}: ${input.notes} | ${existing}`\n : input.notes;\n }\n const sheetRow = rowIdx + 1;\n await updateRow(\n WEDDING_SHEET_ID,\n `Guests!A${sheetRow}:R${sheetRow}`,\n updated,\n );\n return JSON.stringify({\n success: true,\n guest: rows[rowIdx][1],\n rsvp: input.rsvp_status,\n });\n }\n\n case \"log_wedding_decision\": {\n const rows = await readRange(\"Decisions!A:A\", false, WEDDING_SHEET_ID);\n const existingIds = rows.slice(1).map((r) => r[0] || \"\").filter((s) =>\n s.startsWith(\"D\")\n );\n const maxNum = existingIds.length\n ? Math.max(...existingIds.map((id) => parseInt(id.slice(1)) || 0))\n : 0;\n const newId = `D${(maxNum + 1).toString().padStart(3, \"0\")}`;\n // Order: id, date, decision, category, notes, superseded_by\n const today = new Date().toISOString().slice(0, 10);\n const row = [\n newId,\n today,\n input.decision,\n input.category || \"\",\n input.notes || \"\",\n \"\",\n ];\n await appendRow(WEDDING_SHEET_ID, \"Decisions!A:F\", row);\n return JSON.stringify({\n success: true,\n id: newId,\n decision: input.decision,\n });\n }\n\n case \"get_wedding_budget_summary\": {\n // Read both Vendors and Budget tabs in parallel\n const [vendorRows, budgetRows] = await Promise.all([\n readRange(\"Vendors!A:O\", true, WEDDING_SHEET_ID),\n readRange(\"Budget!A:H\", true, WEDDING_SHEET_ID),\n ]);\n let totalQuoted = 0, totalPaid = 0, totalRemaining = 0;\n const vendorBreakdown: any[] = [];\n for (let i = 1; i < vendorRows.length; i++) {\n const r = vendorRows[i];\n if (!r[0]) continue;\n const quoted = parseFloat(r[7] || \"0\") || 0;\n const paid = parseFloat(r[8] || \"0\") || 0;\n const remaining = parseFloat(r[9] || \"0\") || 0;\n totalQuoted += quoted;\n totalPaid += paid;\n totalRemaining += remaining;\n if (quoted || paid || remaining) {\n vendorBreakdown.push({\n category: r[1],\n name: r[2],\n status: r[6],\n quoted,\n paid,\n remaining,\n });\n }\n }\n let totalEstimated = 0;\n for (let i = 1; i < budgetRows.length; i++) {\n const est = parseFloat(budgetRows[i][3] || \"0\") || 0;\n totalEstimated += est;\n }\n return JSON.stringify({\n total_estimated: totalEstimated,\n total_quoted: totalQuoted,\n total_paid: totalPaid,\n total_remaining: totalRemaining,\n vendor_breakdown: vendorBreakdown,\n });\n }\n\n case \"search_gmail\": {\n const max = Math.min(input.max_results || 10, 25);\n const messages = await gmailSearch(input.query, max);\n return JSON.stringify({ results: messages, count: messages.length });\n }\n\n case \"read_email\": {\n const msg = await gmailReadMessage(input.message_id);\n return JSON.stringify(msg);\n }\n\n case \"read_email_thread\": {\n const messages = await gmailReadThread(input.thread_id);\n return JSON.stringify({ thread_id: input.thread_id, messages });\n }\n\n case \"create_email_draft\": {\n const draft = await gmailCreateDraft(\n input.to,\n input.subject,\n input.body,\n input.thread_id,\n );\n return JSON.stringify({\n success: true,\n draft_id: draft.id,\n message:\n \"Draft saved to your Gmail Drafts folder. Review and send manually.\",\n });\n }\n\n case \"delete_wedding_row\": {\n const tab = input.tab;\n const query = (input.id_or_name || \"\").toLowerCase().trim();\n if (!query) {\n return JSON.stringify({\n success: false,\n reason: \"no id_or_name provided\",\n });\n }\n // Read tab to find the row\n const rows = await readRange(`${tab}!A:Z`, false, WEDDING_SHEET_ID);\n if (rows.length < 2) {\n return JSON.stringify({\n success: false,\n reason: `${tab} tab is empty or only has headers`,\n });\n }\n let rowIdx = -1;\n let matchedText = \"\";\n for (let i = 1; i < rows.length; i++) {\n // Check column A (id) and column B (name/decision/category) for match\n const colA = (rows[i][0] || \"\").toLowerCase();\n const colB = (rows[i][1] || \"\").toLowerCase();\n const colC = (rows[i][2] || \"\").toLowerCase();\n if (\n colA === query || colB === query || colC === query ||\n colA.includes(query) || colB.includes(query) || colC.includes(query)\n ) {\n rowIdx = i;\n matchedText = `${rows[i][0] || \"\"} - ${rows[i][1] || \"\"} - ${\n rows[i][2] || \"\"\n }`.trim();\n break;\n }\n }\n if (rowIdx === -1) {\n return JSON.stringify({\n success: false,\n reason: `no row in ${tab} matched \"${input.id_or_name}\"`,\n });\n }\n await deleteSheetRow(WEDDING_SHEET_ID, tab, rowIdx);\n return JSON.stringify({\n success: true,\n deleted_from: tab,\n deleted_row: matchedText,\n });\n }\n\n case \"clear_wedding_tab\": {\n const deleted = await clearSheetData(WEDDING_SHEET_ID, input.tab);\n return JSON.stringify({\n success: true,\n tab: input.tab,\n rows_deleted: deleted,\n });\n }\n\n default:\n return `Unknown tool: ${name}`;\n }\n}\n\n// ============================================================\n// AGENT LOOP\n// ============================================================\nconst SYSTEM_PROMPT =\n `You are Neesha's personal assistant and chief of staff via Telegram. She is a Kellogg MBA grad (June 2026), job searching for AI operator roles in SF, wedding in June, training for Hood to Coast on August 29, 2026. Today is ${\n new Date().toDateString()\n }.\n\nYou have access to tools to:\n- Manage her todos (Supabase) — for actionable things she needs to do\n- Log runs to her Hood to Coast training sheet\n- Manage her wedding planning sheet — vendors, guests, RSVPs, decisions, budget\n- Generate her daily briefing on demand (web search + synthesis)\n- Search and read her Gmail; create email drafts (saved to Drafts, never auto-sent)\n- Search the web\n\nARCHITECTURE — what goes where:\n- Todos = \"things I need to do\" (find a florist, prep for interview, follow up with X). Goes in Supabase via add_todo.\n- Wedding sheet = structured backend (vendor records with quotes/contracts/status, guest list with RSVPs, major decisions, budget). Use the wedding tools.\n- Hood to Coast sheet = training plan + run log.\n- Gmail = source of truth for vendor contracts, invoices, guest contact info, professional correspondence. Search it when she asks for contract details, invoice amounts, vendor contacts, or thread context. Use create_email_draft for outgoing emails — never auto-send.\n- These don't overlap. Don't write a vendor as a todo. Don't write a todo as a vendor entry.\n\nEMAIL WORKFLOW:\n- When she asks about a vendor's details (cost, contact info, contract terms), search Gmail first, then optionally write findings to the wedding sheet.\n- When she asks to draft an email, use create_email_draft. Match her voice: direct, warm, no fluff, no emojis. Show her the draft body in your reply so she can verify before opening Gmail.\n- Drafts are NEVER auto-sent. Always tell her \"draft saved to Gmail — review and send when ready.\"\n\nDESTRUCTIVE ACTIONS (delete_wedding_row, clear_wedding_tab):\n- ALWAYS describe what will be deleted and ask for explicit confirmation before calling these tools.\n- Example flow: User: \"delete the dummy florist\". You: \"I'll delete V001 - florist - Bloom & Co. Confirm?\" Wait for \"yes\" before calling delete_wedding_row.\n- For clear_wedding_tab, count the rows first by listing them: \"I'll clear all 5 rows from Vendors. Confirm?\"\n- If she says \"delete it\" without specifying which one and there's ambiguity, ask which row before doing anything.\n\nGUIDELINES:\n- Be direct, warm, concise. She reads on her phone. Plain text, no markdown headers, no bullet lists unless she asks. Max ~150 words for most replies.\n- For run logging: when she describes a run, parse details and ASK HER TO CONFIRM. Only call log_run AFTER explicit yes/confirm. After logging, give brief coach feedback with weekly context.\n- For wedding vendor/guest writes: don't ask for confirmation, just do it and confirm it was done. These are quick captures, not high-stakes.\n- For todos: just add them.\n- For coaching feedback: be specific. Reference the Guide if relevant.\n- For briefing: when she says \"give me my briefing,\" \"what's the news,\" \"catch me up\" — call get_daily_briefing. Tell her it'll take 10-15 sec.\n- If she's preparing for a job interview, be a smart sounding board. Don't be sycophantic. Push back when wrong.\n- If she's venting or chatting, just chat. Don't force tools.\n\nCONFIRMATION FLOW for runs:\n1. User describes a run\n2. You parse and reply: \"Got it — confirm: {summary}? Reply yes to log.\"\n3. If next message is yes, NOW call log_run\n4. If no/cancel, acknowledge and don't log\n5. After logging, brief coach feedback with weekly context`;\n\nasync function runAgent(\n chatId: number,\n userMessage: string,\n conversationHistory: any[] = [],\n): Promise {\n const messages = [...conversationHistory, {\n role: \"user\",\n content: userMessage,\n }];\n const maxIterations = 8;\n\n for (let i = 0; i < maxIterations; i++) {\n tgTyping(chatId);\n\n const res = await fetch(\"https://api.anthropic.com/v1/messages\", {\n method: \"POST\",\n headers: {\n \"x-api-key\": ANTHROPIC_KEY,\n \"anthropic-version\": \"2023-06-01\",\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({\n model: \"claude-haiku-4-5-20251001\",\n max_tokens: 1500,\n system: SYSTEM_PROMPT,\n tools: TOOLS,\n messages,\n }),\n });\n\n if (!res.ok) {\n const err = await res.text();\n throw new Error(`claude ${res.status}: ${err}`);\n }\n const data = await res.json();\n\n // Add assistant response to messages\n messages.push({ role: \"assistant\", content: data.content });\n\n // If Claude wants to use tools, execute them (in parallel when multiple)\n if (data.stop_reason === \"tool_use\") {\n const toolUseBlocks = data.content.filter((b: any) =>\n b.type === \"tool_use\"\n );\n\n const toolResults = await Promise.all(\n toolUseBlocks.map(async (block: any) => {\n try {\n const result = await executeTool(block.name, block.input);\n return {\n type: \"tool_result\",\n tool_use_id: block.id,\n content: result,\n };\n } catch (err: any) {\n return {\n type: \"tool_result\",\n tool_use_id: block.id,\n content: `Error: ${err.message}`,\n is_error: true,\n };\n }\n }),\n );\n\n messages.push({ role: \"user\", content: toolResults });\n continue; // loop back, let Claude decide what's next\n }\n\n // Claude is done — extract final text\n const textBlocks = data.content.filter((b: any) => b.type === \"text\");\n return textBlocks.map((b: any) => b.text).join(\"\\n\").trim();\n }\n\n return \"I got stuck in a loop. Try rephrasing?\";\n}\n\n// ============================================================\n// MAIN HANDLER\n// ============================================================\n\n// Per-chat short-term memory (last few turns) — survives within a single Val instance lifetime\nconst conversations = new Map();\nfunction getHistory(chatId: number): any[] {\n return conversations.get(chatId) || [];\n}\nfunction appendHistory(chatId: number, userMsg: string, assistantMsg: string) {\n const hist = getHistory(chatId);\n hist.push({ role: \"user\", content: userMsg });\n hist.push({ role: \"assistant\", content: assistantMsg });\n // Keep last 6 turns (12 messages) to bound context\n while (hist.length > 12) hist.shift();\n conversations.set(chatId, hist);\n}\n\nexport default async function (req: Request): Promise {\n if (req.method !== \"POST\") return new Response(\"ok\");\n\n let update: any;\n try {\n update = await req.json();\n } catch {\n return new Response(\"ok\");\n }\n const msg = update.message;\n if (!msg) return new Response(\"ok\");\n if (String(msg.from.id) !== ALLOWED_USER) {\n await tgReply(msg.chat.id, \"not authorized\");\n return new Response(\"ok\");\n }\n\n // Voice → text\n let text = (msg.text || \"\").trim();\n if (msg.voice) {\n try {\n const audio = await downloadVoice(msg.voice.file_id);\n text = await transcribe(audio);\n if (!text) {\n await tgReply(msg.chat.id, \"couldn't hear that — try again?\");\n return new Response(\"ok\");\n }\n } catch (err: any) {\n await tgReply(msg.chat.id, `voice error: ${err.message}`);\n return new Response(\"ok\");\n }\n }\n if (!text) return new Response(\"ok\");\n\n if (text === \"/start\") {\n await tgReply(\n msg.chat.id,\n \"Hi. I'm your personal assistant. Send me todos, log runs, ask anything.\",\n );\n return new Response(\"ok\");\n }\n if (text === \"/reset\") {\n conversations.delete(msg.chat.id);\n await tgReply(msg.chat.id, \"Conversation reset.\");\n return new Response(\"ok\");\n }\n\n try {\n const history = getHistory(msg.chat.id);\n const reply = await runAgent(msg.chat.id, text, history);\n appendHistory(msg.chat.id, text, reply);\n await tgReply(msg.chat.id, reply);\n } catch (err: any) {\n await tgReply(msg.chat.id, `error: ${err.message}`);\n console.error(err);\n }\n\n return new Response(\"ok\");\n}","// Personal assistant bot — agentic version with tool use\n// Drop-in replacement for telegram-bot-h2c.ts. Same env vars.\n// Create a SECOND val so you can A/B against the working classifier version.\n\nimport {\n create as createJWT,\n getNumericDate,\n} from \"https://deno.land/x/djwt@v3.0.1/mod.ts\";\n\n// ---------- Env ----------\nconst TG_TOKEN = Deno.env.get(\"TELEGRAM_BOT_TOKEN\")!;\nconst SUPABASE_URL = Deno.env.get(\"SUPABASE_URL\")!;\nconst SUPABASE_KEY = Deno.env.get(\"SUPABASE_ANON_KEY\")!;\nconst ANTHROPIC_KEY = Deno.env.get(\"ANTHROPIC_API_KEY\")!;\nconst GROQ_KEY = Deno.env.get(\"GROQ_API_KEY\")!;\nconst ALLOWED_USER = Deno.env.get(\"ALLOWED_USER_ID\")!;\nconst SHEET_ID = Deno.env.get(\"GOOGLE_SHEET_ID\")!;\nconst WEDDING_SHEET_ID = Deno.env.get(\"WEDDING_SHEET_ID\")!;\nconst SA_JSON = Deno.env.get(\"GOOGLE_SERVICE_ACCOUNT_JSON\")!;\nconst GMAIL_CLIENT_ID = Deno.env.get(\"GMAIL_CLIENT_ID\")!;\nconst GMAIL_CLIENT_SECRET = Deno.env.get(\"GMAIL_CLIENT_SECRET\")!;\nconst GMAIL_REFRESH_TOKEN = Deno.env.get(\"GMAIL_REFRESH_TOKEN\")!;\n\n// ---------- Telegram ----------\nasync function tgReply(chatId: number, text: string) {\n const truncated = text.length > 4000 ? text.slice(0, 3997) + \"...\" : text;\n const attempt = async (useMarkdown: boolean) => {\n const body: any = { chat_id: chatId, text: truncated };\n if (useMarkdown) body.parse_mode = \"Markdown\";\n return await fetch(`https://api.telegram.org/bot${TG_TOKEN}/sendMessage`, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify(body),\n });\n };\n let res = await attempt(true);\n if (!res.ok) res = await attempt(false);\n if (!res.ok) console.error(\"tg send failed:\", await res.text());\n}\n\nasync function tgTyping(chatId: number) {\n // Sends \"typing...\" indicator so user knows we're working\n fetch(`https://api.telegram.org/bot${TG_TOKEN}/sendChatAction`, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ chat_id: chatId, action: \"typing\" }),\n }).catch(() => {});\n}\n\n// ---------- Voice ----------\nasync function downloadVoice(fileId: string): Promise {\n const info =\n await (await fetch(\n `https://api.telegram.org/bot${TG_TOKEN}/getFile?file_id=${fileId}`,\n )).json();\n return await (await fetch(\n `https://api.telegram.org/file/bot${TG_TOKEN}/${info.result.file_path}`,\n )).arrayBuffer();\n}\nasync function transcribe(audio: ArrayBuffer): Promise {\n const form = new FormData();\n form.append(\"file\", new Blob([audio], { type: \"audio/ogg\" }), \"voice.ogg\");\n form.append(\"model\", \"whisper-large-v3\");\n const res = await fetch(\n \"https://api.groq.com/openai/v1/audio/transcriptions\",\n {\n method: \"POST\",\n headers: { Authorization: `Bearer ${GROQ_KEY}` },\n body: form,\n },\n );\n if (!res.ok) throw new Error(`groq ${res.status}`);\n return ((await res.json()).text || \"\").trim();\n}\n\n// ---------- Google auth ----------\nlet cachedToken: { token: string; expiresAt: number } | null = null;\nasync function getGoogleToken(): Promise {\n if (cachedToken && cachedToken.expiresAt > Date.now() + 60_000) {\n return cachedToken.token;\n }\n const sa = JSON.parse(SA_JSON);\n const pem = sa.private_key.replace(/-----BEGIN PRIVATE KEY-----/, \"\").replace(\n /-----END PRIVATE KEY-----/,\n \"\",\n ).replace(/\\s/g, \"\");\n const binaryDer = Uint8Array.from(atob(pem), (c) => c.charCodeAt(0));\n const cryptoKey = await crypto.subtle.importKey(\n \"pkcs8\",\n binaryDer.buffer,\n { name: \"RSASSA-PKCS1-v1_5\", hash: \"SHA-256\" },\n false,\n [\"sign\"],\n );\n const jwt = await createJWT(\n { alg: \"RS256\", typ: \"JWT\" },\n {\n iss: sa.client_email,\n scope: \"https://www.googleapis.com/auth/spreadsheets\",\n aud: \"https://oauth2.googleapis.com/token\",\n exp: getNumericDate(3600),\n iat: getNumericDate(0),\n },\n cryptoKey,\n );\n const res = await fetch(\"https://oauth2.googleapis.com/token\", {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/x-www-form-urlencoded\" },\n body:\n `grant_type=urn:ietf:params:oauth:grant-type:jwt-bearer&assertion=${jwt}`,\n });\n if (!res.ok) throw new Error(`google auth: ${await res.text()}`);\n const data = await res.json();\n cachedToken = {\n token: data.access_token,\n expiresAt: Date.now() + data.expires_in * 1000,\n };\n return data.access_token;\n}\n\n// ---------- Sheets (with caching, multi-sheet) ----------\nconst sheetCache = new Map();\nconst CACHE_TTL_MS = 5 * 60_000;\n\nasync function readRange(\n range: string,\n useCache = false,\n sheetId = SHEET_ID,\n): Promise {\n const cacheKey = `${sheetId}:${range}`;\n if (useCache) {\n const cached = sheetCache.get(cacheKey);\n if (cached && cached.expiresAt > Date.now()) return cached.data;\n }\n const token = await getGoogleToken();\n const res = await fetch(\n `https://sheets.googleapis.com/v4/spreadsheets/${sheetId}/values/${\n encodeURIComponent(range)\n }`,\n { headers: { Authorization: `Bearer ${token}` } },\n );\n if (!res.ok) {\n throw new Error(`sheets read ${res.status}: ${await res.text()}`);\n }\n const data = (await res.json()).values || [];\n if (useCache) {\n sheetCache.set(cacheKey, { data, expiresAt: Date.now() + CACHE_TTL_MS });\n }\n return data;\n}\n\nasync function appendRow(sheetId: string, range: string, values: any[]) {\n const token = await getGoogleToken();\n const res = await fetch(\n `https://sheets.googleapis.com/v4/spreadsheets/${sheetId}/values/${\n encodeURIComponent(range)\n }:append?valueInputOption=USER_ENTERED&insertDataOption=INSERT_ROWS`,\n {\n method: \"POST\",\n headers: {\n Authorization: `Bearer ${token}`,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({ values: [values] }),\n },\n );\n if (!res.ok) throw new Error(`sheets append: ${await res.text()}`);\n // Invalidate cache for this sheet\n for (const k of sheetCache.keys()) {\n if (k.startsWith(`${sheetId}:`)) sheetCache.delete(k);\n }\n return await res.json();\n}\n\nasync function updateRow(sheetId: string, range: string, values: any[]) {\n const token = await getGoogleToken();\n const res = await fetch(\n `https://sheets.googleapis.com/v4/spreadsheets/${sheetId}/values/${\n encodeURIComponent(range)\n }?valueInputOption=USER_ENTERED`,\n {\n method: \"PUT\",\n headers: {\n Authorization: `Bearer ${token}`,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({ values: [values] }),\n },\n );\n if (!res.ok) throw new Error(`sheets update: ${await res.text()}`);\n for (const k of sheetCache.keys()) {\n if (k.startsWith(`${sheetId}:`)) sheetCache.delete(k);\n }\n return await res.json();\n}\n\nasync function appendRun(values: any[]) {\n return await appendRow(SHEET_ID, \"Bot Log!A:I\", values);\n}\n\n// Get the numeric sheet ID (gid) for a tab name — required for deleteDimension/batchUpdate\nasync function getSheetGid(\n spreadsheetId: string,\n tabName: string,\n): Promise {\n const token = await getGoogleToken();\n const res = await fetch(\n `https://sheets.googleapis.com/v4/spreadsheets/${spreadsheetId}?fields=sheets.properties`,\n { headers: { Authorization: `Bearer ${token}` } },\n );\n if (!res.ok) throw new Error(`sheets metadata: ${await res.text()}`);\n const data = await res.json();\n const sheet = data.sheets.find((s: any) => s.properties.title === tabName);\n if (!sheet) throw new Error(`Tab \"${tabName}\" not found`);\n return sheet.properties.sheetId;\n}\n\n// Delete a single row (0-indexed). Note: Google Sheets API rows are 0-indexed for delete operations.\nasync function deleteSheetRow(\n spreadsheetId: string,\n tabName: string,\n rowIndex: number,\n) {\n const token = await getGoogleToken();\n const gid = await getSheetGid(spreadsheetId, tabName);\n const res = await fetch(\n `https://sheets.googleapis.com/v4/spreadsheets/${spreadsheetId}:batchUpdate`,\n {\n method: \"POST\",\n headers: {\n Authorization: `Bearer ${token}`,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({\n requests: [{\n deleteDimension: {\n range: {\n sheetId: gid,\n dimension: \"ROWS\",\n startIndex: rowIndex,\n endIndex: rowIndex + 1,\n },\n },\n }],\n }),\n },\n );\n if (!res.ok) throw new Error(`sheets delete: ${await res.text()}`);\n // Invalidate cache\n for (const k of sheetCache.keys()) {\n if (k.startsWith(`${spreadsheetId}:`)) sheetCache.delete(k);\n }\n return await res.json();\n}\n\n// Delete all rows below the header (row 1). Equivalent to \"clear data\".\nasync function clearSheetData(\n spreadsheetId: string,\n tabName: string,\n): Promise {\n const token = await getGoogleToken();\n const gid = await getSheetGid(spreadsheetId, tabName);\n // First get current row count\n const data = await readRange(`${tabName}!A:A`, false, spreadsheetId);\n const rowCount = data.length;\n if (rowCount <= 1) return 0; // only header or empty\n const res = await fetch(\n `https://sheets.googleapis.com/v4/spreadsheets/${spreadsheetId}:batchUpdate`,\n {\n method: \"POST\",\n headers: {\n Authorization: `Bearer ${token}`,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({\n requests: [{\n deleteDimension: {\n range: {\n sheetId: gid,\n dimension: \"ROWS\",\n startIndex: 1, // keep header (row 0)\n endIndex: rowCount,\n },\n },\n }],\n }),\n },\n );\n if (!res.ok) throw new Error(`sheets clear: ${await res.text()}`);\n for (const k of sheetCache.keys()) {\n if (k.startsWith(`${spreadsheetId}:`)) sheetCache.delete(k);\n }\n return rowCount - 1; // number of data rows deleted\n}\n\n// ---------- Gmail auth (user OAuth refresh token) ----------\nlet cachedGmailToken: { token: string; expiresAt: number } | null = null;\nasync function getGmailToken(): Promise {\n if (cachedGmailToken && cachedGmailToken.expiresAt > Date.now() + 60_000) {\n return cachedGmailToken.token;\n }\n const res = await fetch(\"https://oauth2.googleapis.com/token\", {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/x-www-form-urlencoded\" },\n body: new URLSearchParams({\n client_id: GMAIL_CLIENT_ID,\n client_secret: GMAIL_CLIENT_SECRET,\n refresh_token: GMAIL_REFRESH_TOKEN,\n grant_type: \"refresh_token\",\n }).toString(),\n });\n if (!res.ok) throw new Error(`gmail auth: ${await res.text()}`);\n const data = await res.json();\n cachedGmailToken = {\n token: data.access_token,\n expiresAt: Date.now() + data.expires_in * 1000,\n };\n return data.access_token;\n}\n\n// ---------- Gmail helpers ----------\nfunction decodeBase64Url(str: string): string {\n const b64 = str.replace(/-/g, \"+\").replace(/_/g, \"/\");\n const padded = b64 + \"=\".repeat((4 - b64.length % 4) % 4);\n try {\n return new TextDecoder(\"utf-8\").decode(\n Uint8Array.from(atob(padded), (c) => c.charCodeAt(0)),\n );\n } catch {\n return \"\";\n }\n}\nfunction extractEmailBody(payload: any): string {\n if (!payload) return \"\";\n if (payload.body?.data) return decodeBase64Url(payload.body.data);\n if (payload.parts) {\n // Prefer text/plain, fall back to text/html stripped\n const plain = payload.parts.find((p: any) => p.mimeType === \"text/plain\");\n if (plain?.body?.data) return decodeBase64Url(plain.body.data);\n const html = payload.parts.find((p: any) => p.mimeType === \"text/html\");\n if (html?.body?.data) {\n return decodeBase64Url(html.body.data).replace(/<[^>]+>/g, \" \").replace(\n /\\s+/g,\n \" \",\n );\n }\n // Recurse into multipart/* parts\n for (const part of payload.parts) {\n const nested = extractEmailBody(part);\n if (nested) return nested;\n }\n }\n return \"\";\n}\nfunction getHeader(headers: any[], name: string): string {\n return headers?.find((h: any) => h.name.toLowerCase() === name.toLowerCase())\n ?.value || \"\";\n}\n\nasync function gmailSearch(query: string, maxResults = 10): Promise {\n const token = await getGmailToken();\n const res = await fetch(\n `https://gmail.googleapis.com/gmail/v1/users/me/messages?q=${\n encodeURIComponent(query)\n }&maxResults=${maxResults}`,\n { headers: { Authorization: `Bearer ${token}` } },\n );\n if (!res.ok) throw new Error(`gmail search: ${await res.text()}`);\n const data = await res.json();\n if (!data.messages) return [];\n // Fetch metadata for each message in parallel\n const details = await Promise.all(\n data.messages.map(async (m: any) => {\n const r = await fetch(\n `https://gmail.googleapis.com/gmail/v1/users/me/messages/${m.id}?format=metadata&metadataHeaders=From&metadataHeaders=To&metadataHeaders=Subject&metadataHeaders=Date`,\n { headers: { Authorization: `Bearer ${token}` } },\n );\n if (!r.ok) return null;\n const msg = await r.json();\n return {\n id: msg.id,\n threadId: msg.threadId,\n snippet: msg.snippet,\n from: getHeader(msg.payload.headers, \"From\"),\n to: getHeader(msg.payload.headers, \"To\"),\n subject: getHeader(msg.payload.headers, \"Subject\"),\n date: getHeader(msg.payload.headers, \"Date\"),\n };\n }),\n );\n return details.filter(Boolean);\n}\n\nasync function gmailReadMessage(messageId: string): Promise {\n const token = await getGmailToken();\n const res = await fetch(\n `https://gmail.googleapis.com/gmail/v1/users/me/messages/${messageId}?format=full`,\n { headers: { Authorization: `Bearer ${token}` } },\n );\n if (!res.ok) throw new Error(`gmail read: ${await res.text()}`);\n const msg = await res.json();\n return {\n id: msg.id,\n threadId: msg.threadId,\n from: getHeader(msg.payload.headers, \"From\"),\n to: getHeader(msg.payload.headers, \"To\"),\n subject: getHeader(msg.payload.headers, \"Subject\"),\n date: getHeader(msg.payload.headers, \"Date\"),\n body: extractEmailBody(msg.payload).slice(0, 5000), // cap at 5k chars to avoid context bloat\n };\n}\n\nasync function gmailReadThread(threadId: string): Promise {\n const token = await getGmailToken();\n const res = await fetch(\n `https://gmail.googleapis.com/gmail/v1/users/me/threads/${threadId}?format=full`,\n { headers: { Authorization: `Bearer ${token}` } },\n );\n if (!res.ok) throw new Error(`gmail thread: ${await res.text()}`);\n const data = await res.json();\n return data.messages.map((msg: any) => ({\n id: msg.id,\n from: getHeader(msg.payload.headers, \"From\"),\n to: getHeader(msg.payload.headers, \"To\"),\n subject: getHeader(msg.payload.headers, \"Subject\"),\n date: getHeader(msg.payload.headers, \"Date\"),\n body: extractEmailBody(msg.payload).slice(0, 3000),\n }));\n}\n\nasync function gmailCreateDraft(\n to: string,\n subject: string,\n body: string,\n threadId?: string,\n): Promise {\n const token = await getGmailToken();\n // Build RFC 2822 message\n const messageLines = [\n `To: ${to}`,\n `Subject: ${subject}`,\n `Content-Type: text/plain; charset=\"UTF-8\"`,\n \"\",\n body,\n ];\n const rawMessage = messageLines.join(\"\\r\\n\");\n // Base64url encode\n const encoded = btoa(rawMessage).replace(/\\+/g, \"-\").replace(/\\//g, \"_\")\n .replace(/=+$/, \"\");\n const draftBody: any = { message: { raw: encoded } };\n if (threadId) draftBody.message.threadId = threadId;\n const res = await fetch(\n \"https://gmail.googleapis.com/gmail/v1/users/me/drafts\",\n {\n method: \"POST\",\n headers: {\n Authorization: `Bearer ${token}`,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify(draftBody),\n },\n );\n if (!res.ok) throw new Error(`gmail draft: ${await res.text()}`);\n return await res.json();\n}\n\n// ---------- Week math ----------\nconst RACE_DAY = new Date(\"2026-08-29\");\nconst WEEK_1_START = new Date(\"2026-03-29\");\nfunction weekForDate(d: Date): number | null {\n if (d < WEEK_1_START || d > RACE_DAY) return null;\n return Math.floor((d.getTime() - WEEK_1_START.getTime()) / (7 * 86400_000)) +\n 1;\n}\n\n// ---------- Supabase (todos) ----------\nasync function sbFetch(path: string, opts: any = {}) {\n const res = await fetch(`${SUPABASE_URL}/rest/v1/${path}`, {\n ...opts,\n headers: {\n apikey: SUPABASE_KEY,\n Authorization: `Bearer ${SUPABASE_KEY}`,\n \"Content-Type\": \"application/json\",\n Prefer: \"return=representation\",\n ...(opts.headers || {}),\n },\n });\n if (!res.ok) throw new Error(`supabase ${res.status}: ${await res.text()}`);\n if (opts.method === \"DELETE\" || res.status === 204) return null;\n const text = await res.text();\n return text ? JSON.parse(text) : null;\n}\n\n// ---------- Pace helpers ----------\nfunction timeToSeconds(t: string): number {\n const parts = t.split(\":\").map(Number);\n if (parts.length === 3) return parts[0] * 3600 + parts[1] * 60 + parts[2];\n if (parts.length === 2) return parts[0] * 60 + parts[1];\n return 0;\n}\nfunction secondsToPace(secs: number, miles: number): string {\n if (!miles || miles <= 0) return \"\";\n const paceSec = Math.round(secs / miles);\n const m = Math.floor(paceSec / 60);\n const s = paceSec % 60;\n return `${m}:${s.toString().padStart(2, \"0\")}`;\n}\n\n// ---------- Pending confirmation cache ----------\nconst pendingConfirms = new Map<\n number,\n { kind: string; data: any; expires: number }\n>();\nfunction setPending(chatId: number, kind: string, data: any) {\n pendingConfirms.set(chatId, { kind, data, expires: Date.now() + 5 * 60_000 });\n}\nfunction getPending(chatId: number) {\n const p = pendingConfirms.get(chatId);\n if (!p || p.expires < Date.now()) {\n pendingConfirms.delete(chatId);\n return null;\n }\n return p;\n}\n\n// ============================================================\n// TOOL DEFINITIONS\n// ============================================================\nconst TOOLS = [\n // ----- Hood to Coast -----\n {\n name: \"get_todays_plan\",\n description:\n \"Read today's planned workout from the Hood to Coast training plan. Use this when the user asks what they should run today, what's scheduled, or before logging a run to compare actual vs planned.\",\n input_schema: { type: \"object\", properties: {} },\n },\n {\n name: \"get_week_progress\",\n description:\n \"Get the user's logged miles vs planned miles for a specific training week (1-22). Use this when the user asks how they're tracking, what's left, or before logging a run to give weekly context.\",\n input_schema: {\n type: \"object\",\n properties: {\n week: { type: \"number\", description: \"Training week number 1-22\" },\n },\n required: [\"week\"],\n },\n },\n {\n name: \"get_recent_runs\",\n description:\n \"Get the user's most recent logged runs/workouts (default 5). Use to spot trends, check feel scores, see what they've been doing.\",\n input_schema: {\n type: \"object\",\n properties: {\n limit: {\n type: \"number\",\n description: \"How many recent entries (default 5)\",\n },\n },\n },\n },\n {\n name: \"get_guide_info\",\n description:\n \"Read the Hood to Coast guide tab — contains pace targets, non-negotiables (e.g., rest if hurt 2+ days), strength routine, etc. Use when the user asks training questions.\",\n input_schema: { type: \"object\", properties: {} },\n },\n {\n name: \"log_run\",\n description:\n \"Write a new run/workout entry to the Bot Log sheet. ONLY call this AFTER the user has explicitly confirmed (said yes/confirm/log it). To propose a run for confirmation, just describe it in your reply and ASK the user to confirm — do not call this tool until they say yes.\",\n input_schema: {\n type: \"object\",\n properties: {\n miles: { type: \"number\" },\n time: { type: \"string\", description: \"Format h:mm:ss (e.g. 0:39:21)\" },\n feel: { type: \"number\", description: \"1-10 effort/quality rating\" },\n workout: {\n type: \"string\",\n description: \"Run, Strength, Pilates, Brick, etc\",\n },\n notes: { type: \"string\" },\n date: {\n type: \"string\",\n description: \"ISO date YYYY-MM-DD; defaults to today if omitted\",\n },\n },\n required: [\"workout\"],\n },\n },\n\n // ----- Todos -----\n {\n name: \"list_todos\",\n description:\n \"List the user's open todos. Optionally filter by category (inbox, school, career, personal).\",\n input_schema: {\n type: \"object\",\n properties: {\n category: {\n type: \"string\",\n enum: [\"inbox\", \"school\", \"career\", \"personal\", \"all\"],\n },\n },\n },\n },\n {\n name: \"add_todo\",\n description:\n \"Add a new todo. Defaults to inbox; user can specify category. Use for any actionable thing the user wants to remember to do.\",\n input_schema: {\n type: \"object\",\n properties: {\n task: { type: \"string\" },\n category: {\n type: \"string\",\n enum: [\"inbox\", \"school\", \"career\", \"personal\"],\n },\n },\n required: [\"task\"],\n },\n },\n {\n name: \"complete_todo\",\n description:\n \"Mark a todo as done. Pass the task description to fuzzy-match.\",\n input_schema: {\n type: \"object\",\n properties: {\n task_description: {\n type: \"string\",\n description:\n \"Description of the todo to complete; will be matched semantically\",\n },\n },\n required: [\"task_description\"],\n },\n },\n\n // ----- General -----\n {\n name: \"web_search\",\n description:\n \"Search the web for current information (weather, news, recent events, etc). Use when the user asks about anything time-sensitive or factual you need to verify.\",\n input_schema: {\n type: \"object\",\n properties: { query: { type: \"string\" } },\n required: [\"query\"],\n },\n },\n\n // ----- Daily briefing on demand -----\n {\n name: \"get_daily_briefing\",\n description:\n \"Generate the user's daily briefing on demand — same content as her scheduled morning briefing. Use this when she explicitly asks for a briefing, news roundup, what's happening today, or 'catch me up'. This takes ~10-15 seconds because it does live web research.\",\n input_schema: { type: \"object\", properties: {} },\n },\n\n // ----- Wedding: vendors -----\n {\n name: \"list_vendors\",\n description:\n \"List wedding vendors with their status, costs, and notes. Optionally filter by category (florist, DJ, venue, photographer, etc) or status (researching, quoted, booked, etc).\",\n input_schema: {\n type: \"object\",\n properties: {\n category: {\n type: \"string\",\n description: \"Filter by vendor category (optional)\",\n },\n status: { type: \"string\", description: \"Filter by status (optional)\" },\n },\n },\n },\n {\n name: \"add_vendor\",\n description:\n \"Add a new wedding vendor to the Vendors tab. Use when the user mentions researching, contacting, or working with a new vendor.\",\n input_schema: {\n type: \"object\",\n properties: {\n category: {\n type: \"string\",\n description: \"florist, DJ, venue, photographer, caterer, etc\",\n },\n name: { type: \"string\", description: \"Business name\" },\n contact_name: { type: \"string\" },\n email: { type: \"string\" },\n phone: { type: \"string\" },\n status: {\n type: \"string\",\n description: \"researching, contacted, quoted, booked, declined\",\n },\n quote_amount: { type: \"number\" },\n deposit_paid: { type: \"number\" },\n balance_due: { type: \"number\" },\n balance_due_date: { type: \"string\", description: \"YYYY-MM-DD\" },\n next_action: { type: \"string\" },\n notes: { type: \"string\" },\n },\n required: [\"category\", \"name\"],\n },\n },\n {\n name: \"update_vendor\",\n description:\n \"Update fields on an existing vendor row. Pass the vendor's id (e.g. V001) or unique name to identify it, plus any fields to change.\",\n input_schema: {\n type: \"object\",\n properties: {\n vendor_id_or_name: {\n type: \"string\",\n description: \"Vendor ID like V001 or business name like 'Bloom & Co'\",\n },\n status: { type: \"string\" },\n quote_amount: { type: \"number\" },\n deposit_paid: { type: \"number\" },\n balance_due: { type: \"number\" },\n balance_due_date: { type: \"string\" },\n last_contact_date: {\n type: \"string\",\n description:\n \"YYYY-MM-DD; defaults to today if not provided and the user just had contact\",\n },\n next_action: { type: \"string\" },\n notes: {\n type: \"string\",\n description:\n \"If updating notes, prepend new info to existing notes; don't overwrite blindly\",\n },\n },\n required: [\"vendor_id_or_name\"],\n },\n },\n\n // ----- Wedding: guests -----\n {\n name: \"list_guests\",\n description:\n \"List wedding guests. Filter by RSVP status (pending, yes, no, maybe), side (Neesha, Tony), tier (A, B, C), or dietary restriction.\",\n input_schema: {\n type: \"object\",\n properties: {\n rsvp_status: { type: \"string\" },\n side: { type: \"string\" },\n tier: { type: \"string\" },\n },\n },\n },\n {\n name: \"add_guest\",\n description: \"Add a new guest to the wedding guest list.\",\n input_schema: {\n type: \"object\",\n properties: {\n name: { type: \"string\" },\n side: { type: \"string\", description: \"Neesha or Tony\" },\n relationship: {\n type: \"string\",\n description: \"friend, family, work, etc\",\n },\n tier: {\n type: \"string\",\n description: \"A (must invite), B (next round), C (if space)\",\n },\n email: { type: \"string\" },\n phone: { type: \"string\" },\n plus_one_allowed: { type: \"boolean\" },\n plus_one_name: { type: \"string\" },\n notes: { type: \"string\" },\n },\n required: [\"name\"],\n },\n },\n {\n name: \"update_rsvp\",\n description: \"Update a guest's RSVP status when they respond.\",\n input_schema: {\n type: \"object\",\n properties: {\n guest_id_or_name: {\n type: \"string\",\n description: \"Guest ID like G001 or full name\",\n },\n rsvp_status: { type: \"string\", description: \"yes, no, maybe, pending\" },\n plus_one_name: {\n type: \"string\",\n description: \"If they're bringing one — name of plus one\",\n },\n dietary: { type: \"string\" },\n song_request: { type: \"string\" },\n notes: { type: \"string\" },\n },\n required: [\"guest_id_or_name\", \"rsvp_status\"],\n },\n },\n\n // ----- Wedding: decisions -----\n {\n name: \"log_wedding_decision\",\n description:\n \"Record a major wedding decision in the Decisions tab. Use when the user makes or describes a final choice about the wedding (venue, date, theme, etc).\",\n input_schema: {\n type: \"object\",\n properties: {\n decision: {\n type: \"string\",\n description: \"The decision in one sentence\",\n },\n category: {\n type: \"string\",\n description: \"venue, ceremony, reception, food, etc\",\n },\n notes: { type: \"string\" },\n },\n required: [\"decision\"],\n },\n },\n\n // ----- Wedding: budget summary -----\n {\n name: \"get_wedding_budget_summary\",\n description:\n \"Read the budget tab and vendors to give a quick financial snapshot — total estimated, total quoted, total paid, total remaining.\",\n input_schema: { type: \"object\", properties: {} },\n },\n\n // ----- Gmail -----\n {\n name: \"search_gmail\",\n description:\n \"Search Neesha's Gmail inbox. Use Gmail search syntax (e.g., 'from:florist', 'subject:invoice', 'love and wolves', 'has:attachment vendor'). Returns a list of matching messages with from/subject/date/snippet but NOT full body. Call read_email to get the full body of a specific message.\",\n input_schema: {\n type: \"object\",\n properties: {\n query: { type: \"string\", description: \"Gmail search query\" },\n max_results: {\n type: \"number\",\n description: \"Max messages to return (default 10, max 25)\",\n },\n },\n required: [\"query\"],\n },\n },\n {\n name: \"read_email\",\n description:\n \"Read the full body of a specific email by message ID (from search_gmail results). Returns from, to, subject, date, and full body.\",\n input_schema: {\n type: \"object\",\n properties: { message_id: { type: \"string\" } },\n required: [\"message_id\"],\n },\n },\n {\n name: \"read_email_thread\",\n description:\n \"Read all messages in an email thread by thread ID. Useful when an email has back-and-forth context (negotiations, scheduling).\",\n input_schema: {\n type: \"object\",\n properties: { thread_id: { type: \"string\" } },\n required: [\"thread_id\"],\n },\n },\n {\n name: \"create_email_draft\",\n description:\n \"Create a draft email saved to Neesha's Drafts folder in Gmail. She will review and send manually — this does NOT auto-send. Use when she asks to draft a reply, follow up with a vendor, etc. If replying to an existing thread, pass thread_id to keep it in the same thread.\",\n input_schema: {\n type: \"object\",\n properties: {\n to: { type: \"string\", description: \"Recipient email address\" },\n subject: { type: \"string\" },\n body: {\n type: \"string\",\n description:\n \"Plain text email body. Match Neesha's voice: direct, warm, no fluff, no emojis unless she usually uses them.\",\n },\n thread_id: {\n type: \"string\",\n description: \"Optional — Gmail thread ID if this is a reply\",\n },\n },\n required: [\"to\", \"subject\", \"body\"],\n },\n },\n\n // ----- Wedding: delete / clear -----\n {\n name: \"delete_wedding_row\",\n description:\n \"Delete a specific row from a tab in the wedding sheet (Vendors, Guests, Tasks, Decisions, or Budget). CRITICAL: Before calling this tool, you MUST describe what will be deleted and ask the user to confirm. Only call this AFTER the user has explicitly confirmed (yes/confirm/delete it). Never call without confirmation.\",\n input_schema: {\n type: \"object\",\n properties: {\n tab: {\n type: \"string\",\n enum: [\"Vendors\", \"Guests\", \"Tasks\", \"Decisions\", \"Budget\"],\n },\n id_or_name: {\n type: \"string\",\n description:\n \"ID (V001, G001, etc) or unique name/text to find the row to delete\",\n },\n },\n required: [\"tab\", \"id_or_name\"],\n },\n },\n {\n name: \"clear_wedding_tab\",\n description:\n \"Delete ALL data rows from a wedding tab (keeps the header row). Use for clearing dummy/test data. CRITICAL: Always describe exactly which tab and how many rows will be cleared, then wait for explicit user confirmation (yes/confirm). Never call without confirmation. Destructive and cannot be undone except via Google Sheets manual undo (Ctrl+Z) right after.\",\n input_schema: {\n type: \"object\",\n properties: {\n tab: {\n type: \"string\",\n enum: [\"Vendors\", \"Guests\", \"Tasks\", \"Decisions\", \"Budget\"],\n },\n },\n required: [\"tab\"],\n },\n },\n];\n\n// ============================================================\n// TOOL EXECUTORS\n// ============================================================\nasync function executeTool(name: string, input: any): Promise {\n switch (name) {\n case \"get_todays_plan\": {\n const today = new Date();\n const week = weekForDate(today);\n if (!week) {\n return \"Today is outside the training plan window (plan runs Mar 29 - Aug 29, 2026).\";\n }\n const rows = await readRange(`Plan!A${4 + week}:K${4 + week}`, true); // cached\n if (!rows.length) return \"No plan row found.\";\n const row = rows[0];\n const dayIdx = today.getDay();\n const dayName =\n [\n \"Sunday\",\n \"Monday\",\n \"Tuesday\",\n \"Wednesday\",\n \"Thursday\",\n \"Friday\",\n \"Saturday\",\n ][dayIdx];\n const workout = row[3 + dayIdx] || \"Rest\";\n const phase = row[2] || \"\";\n const weekTotal = row[10] || \"0\";\n return JSON.stringify({\n date: today.toDateString(),\n week,\n day: dayName,\n phase,\n todays_workout: workout,\n week_planned_total_mi: weekTotal,\n });\n }\n\n case \"get_week_progress\": {\n const week = input.week;\n // Run these two reads in parallel\n const [logRows, planRow] = await Promise.all([\n readRange(`Bot Log!A5:I1000`),\n readRange(`Plan!A${4 + week}:K${4 + week}`, true), // plan is cached\n ]);\n const logged = logRows.filter((r: any[]) => parseInt(r[1]) === week);\n const totalMiles = logged.reduce(\n (s: number, r: any[]) => s + (parseFloat(r[3]) || 0),\n 0,\n );\n const planTotal = planRow.length ? parseFloat(planRow[0][10] || \"0\") : 0;\n return JSON.stringify({\n week,\n logged_count: logged.length,\n actual_miles: totalMiles.toFixed(1),\n planned_miles: planTotal,\n pct_complete: planTotal > 0\n ? Math.round((totalMiles / planTotal) * 100)\n : 0,\n sessions: logged.map((r: any[]) => ({\n date: r[0],\n workout: r[2],\n miles: r[3],\n time: r[4],\n pace: r[5],\n feel: r[6],\n notes: r[7],\n })),\n });\n }\n\n case \"get_recent_runs\": {\n const limit = input.limit || 5;\n const rows = await readRange(`Bot Log!A5:I1000`);\n const recent = rows.slice(-limit).reverse();\n return JSON.stringify(\n recent.map((r: any[]) => ({\n date: r[0],\n week: r[1],\n workout: r[2],\n miles: r[3],\n time: r[4],\n pace: r[5],\n feel: r[6],\n notes: r[7],\n })),\n );\n }\n\n case \"get_guide_info\": {\n const rows = await readRange(`Guide!A1:B100`, true); // cached\n return rows.map((r: any[]) => `${r[0] || \"\"} ${r[1] || \"\"}`).filter((s) =>\n s.trim()\n ).join(\"\\n\");\n }\n\n case \"log_run\": {\n const date = input.date ? new Date(input.date) : new Date();\n const week = weekForDate(date) || 0;\n const dateStr = `${(date.getMonth() + 1).toString().padStart(2, \"0\")}/${\n date.getDate().toString().padStart(2, \"0\")\n }/${date.getFullYear()}`;\n const miles = input.miles || \"\";\n const time = input.time || \"\";\n let pace = \"\";\n if (miles && time) {\n pace = secondsToPace(timeToSeconds(time), miles);\n }\n const row = [\n dateStr,\n week,\n input.workout,\n miles,\n time,\n pace,\n input.feel || \"\",\n input.notes || \"\",\n \"bot\",\n ];\n await appendRun(row);\n return JSON.stringify({\n success: true,\n logged: { date: dateStr, week, ...input, pace },\n });\n }\n\n case \"list_todos\": {\n const cat = input.category;\n const todos = await sbFetch(\n \"todos?status=eq.open&order=sort_order.asc,created_at.asc\",\n );\n const filtered = !cat || cat === \"all\"\n ? todos\n : todos.filter((t: any) => (t.category || \"inbox\") === cat);\n return JSON.stringify(\n filtered.map((t: any) => ({\n id: t.id,\n task: t.task,\n category: t.category || \"inbox\",\n starred: t.starred,\n })),\n );\n }\n\n case \"add_todo\": {\n const result = await sbFetch(\"todos\", {\n method: \"POST\",\n body: JSON.stringify({\n task: input.task,\n category: input.category || \"inbox\",\n priority: 3,\n sort_order: Date.now(),\n }),\n });\n return JSON.stringify({ success: true, added: result?.[0] });\n }\n\n case \"complete_todo\": {\n const todos = await sbFetch(\"todos?status=eq.open\");\n const desc = input.task_description.toLowerCase();\n const match = todos.find((t: any) =>\n t.task.toLowerCase().includes(desc) ||\n desc.includes(t.task.toLowerCase())\n );\n if (!match) {\n return JSON.stringify({\n success: false,\n reason: \"no matching todo found\",\n });\n }\n await sbFetch(`todos?id=eq.${match.id}`, {\n method: \"PATCH\",\n body: JSON.stringify({\n status: \"done\",\n completed_at: new Date().toISOString(),\n }),\n });\n return JSON.stringify({ success: true, completed: match.task });\n }\n\n case \"web_search\": {\n // Use Claude with web_search tool for the actual search\n const res = await fetch(\"https://api.anthropic.com/v1/messages\", {\n method: \"POST\",\n headers: {\n \"x-api-key\": ANTHROPIC_KEY,\n \"anthropic-version\": \"2023-06-01\",\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({\n model: \"claude-haiku-4-5-20251001\",\n max_tokens: 800,\n messages: [{\n role: \"user\",\n content:\n `Search the web for: ${input.query}. Reply with a concise factual answer.`,\n }],\n tools: [{ type: \"web_search_20250305\", name: \"web_search\" }],\n }),\n });\n if (!res.ok) return `Search failed: ${res.status}`;\n const json = await res.json();\n return json.content.filter((b: any) => b.type === \"text\").map((b: any) =>\n b.text\n ).join(\"\\n\").trim();\n }\n\n case \"get_daily_briefing\": {\n // Same prompt as the scheduled briefing val, run on demand\n const today = new Date().toLocaleDateString(\"en-US\", {\n weekday: \"long\",\n month: \"long\",\n day: \"numeric\",\n year: \"numeric\",\n timeZone: \"America/Chicago\",\n });\n const briefingPrompt =\n `You are Neesha's chief of staff. Write her on-demand briefing for ${today}.\n\nShe cares about:\n- AI/tech funding rounds (Seed-Series C) at AI companies, especially from Sequoia, a16z, Greylock, Benchmark, Founders Fund, Iconiq, Lightspeed, Index, Accel, Khosla, Greenoaks\n- Tech acquisitions, especially AI/agents/enterprise SaaS\n- Major releases or news from Anthropic, OpenAI, Google DeepMind\n- Public statements/essays/podcasts from Dario Amodei, Bret Taylor, Marc Benioff, Sam Altman\n- Customer wins or strategic moves from agent companies (Sierra, Decagon, Cresta, Adept, Cognition, Harvey)\n- Geopolitical: Middle East (Iran, Hormuz), US-China tech relations, major energy/election news\n\nSkip: generic AI thinkpieces, daily stock fluctuations, celebrity/sports/entertainment, repeat coverage, minor product features.\n\nINSTRUCTIONS:\n- Use web search to find what's actually happened in the past 24 hours.\n- Filter ruthlessly. 4-6 items max. Better to surface 3 great items than 8 mediocre ones.\n- 1-2 sentences per item. Sharp, factual, no hype.\n- Use *bold* for category headers. Plain text otherwise. Telegram-friendly.\n- If almost nothing happened, say so directly. Don't pad.\n\nFormat:\n*${today}*\n\n*AI / TECH*\n- Item 1\n- Item 2\n\n*GEOPOLITICAL*\n- Item 1\n\nKeep total under 250 words.`;\n\n const res = await fetch(\"https://api.anthropic.com/v1/messages\", {\n method: \"POST\",\n headers: {\n \"x-api-key\": ANTHROPIC_KEY,\n \"anthropic-version\": \"2023-06-01\",\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({\n model: \"claude-opus-4-7\", // Opus for better synthesis on this one\n max_tokens: 2500,\n messages: [{ role: \"user\", content: briefingPrompt }],\n tools: [{ type: \"web_search_20250305\", name: \"web_search\" }],\n }),\n });\n if (!res.ok) return `Briefing failed: ${res.status}`;\n const json = await res.json();\n const text = json.content.filter((b: any) => b.type === \"text\").map((\n b: any,\n ) => b.text).join(\"\\n\").trim();\n return text;\n }\n\n // ===== Wedding: vendors =====\n case \"list_vendors\": {\n const rows = await readRange(\"Vendors!A:O\", true, WEDDING_SHEET_ID);\n if (rows.length < 2) return JSON.stringify({ vendors: [] });\n const headers = rows[0];\n const vendors = rows.slice(1)\n .filter((r) => r[0]) // skip empty rows\n .map((r) =>\n Object.fromEntries(\n headers.map((h: string, i: number) => [h, r[i] || \"\"]),\n )\n );\n let filtered = vendors;\n if (input.category) {\n const cat = input.category.toLowerCase();\n filtered = filtered.filter((v: any) =>\n (v.category || \"\").toLowerCase().includes(cat)\n );\n }\n if (input.status) {\n const st = input.status.toLowerCase();\n filtered = filtered.filter((v: any) =>\n (v.status || \"\").toLowerCase().includes(st)\n );\n }\n return JSON.stringify({ vendors: filtered });\n }\n\n case \"add_vendor\": {\n // Find next vendor ID\n const rows = await readRange(\"Vendors!A:A\", false, WEDDING_SHEET_ID);\n const existingIds = rows.slice(1).map((r) => r[0] || \"\").filter((s) =>\n s.startsWith(\"V\")\n );\n const maxNum = existingIds.length\n ? Math.max(...existingIds.map((id) => parseInt(id.slice(1)) || 0))\n : 0;\n const newId = `V${(maxNum + 1).toString().padStart(3, \"0\")}`;\n // Order from sheet: id, category, name, contact_name, email, phone, status, quote_amount, deposit_paid, balance_due, balance_due_date, contract_link, last_contact_date, next_action, notes\n const today = new Date().toISOString().slice(0, 10);\n const row = [\n newId,\n input.category,\n input.name,\n input.contact_name || \"\",\n input.email || \"\",\n input.phone || \"\",\n input.status || \"researching\",\n input.quote_amount ?? \"\",\n input.deposit_paid ?? \"\",\n input.balance_due ?? \"\",\n input.balance_due_date || \"\",\n \"\", // contract_link\n today,\n input.next_action || \"\",\n input.notes || \"\",\n ];\n await appendRow(WEDDING_SHEET_ID, \"Vendors!A:O\", row);\n return JSON.stringify({ success: true, id: newId, vendor: input.name });\n }\n\n case \"update_vendor\": {\n const rows = await readRange(\"Vendors!A:O\", false, WEDDING_SHEET_ID);\n if (rows.length < 2) {\n return JSON.stringify({ success: false, reason: \"no vendors\" });\n }\n const idQuery = (input.vendor_id_or_name || \"\").toLowerCase();\n const headers = rows[0];\n let rowIdx = -1;\n for (let i = 1; i < rows.length; i++) {\n const id = (rows[i][0] || \"\").toLowerCase();\n const name = (rows[i][2] || \"\").toLowerCase();\n if (id === idQuery || name === idQuery || name.includes(idQuery)) {\n rowIdx = i;\n break;\n }\n }\n if (rowIdx === -1) {\n return JSON.stringify({\n success: false,\n reason: `no vendor matched \"${input.vendor_id_or_name}\"`,\n });\n }\n const current = rows[rowIdx];\n // Map field names to column indices\n const fieldMap: Record = {\n status: 6,\n quote_amount: 7,\n deposit_paid: 8,\n balance_due: 9,\n balance_due_date: 10,\n last_contact_date: 12,\n next_action: 13,\n notes: 14,\n };\n const updated = [...current];\n for (const [field, value] of Object.entries(input)) {\n if (field === \"vendor_id_or_name\") continue;\n if (field in fieldMap) {\n if (field === \"notes\" && current[14] && value) {\n // Prepend new note to existing notes with date\n const today = new Date().toISOString().slice(0, 10);\n updated[14] = `${today}: ${value} | ${current[14]}`;\n } else {\n updated[fieldMap[field]] = value as any;\n }\n }\n }\n // If user passed last_contact_date implicitly (because they just had contact), set it\n if (\n !input.last_contact_date &&\n (input.notes || input.next_action || input.status)\n ) {\n updated[12] = new Date().toISOString().slice(0, 10);\n }\n const sheetRow = rowIdx + 1; // 1-indexed for sheets\n await updateRow(\n WEDDING_SHEET_ID,\n `Vendors!A${sheetRow}:O${sheetRow}`,\n updated,\n );\n return JSON.stringify({ success: true, updated_vendor: current[2] });\n }\n\n // ===== Wedding: guests =====\n case \"list_guests\": {\n const rows = await readRange(\"Guests!A:R\", true, WEDDING_SHEET_ID);\n if (rows.length < 2) return JSON.stringify({ guests: [], count: 0 });\n const headers = rows[0];\n const guests = rows.slice(1)\n .filter((r) => r[0])\n .map((r) =>\n Object.fromEntries(\n headers.map((h: string, i: number) => [h, r[i] || \"\"]),\n )\n );\n let filtered = guests;\n if (input.rsvp_status) {\n const s = input.rsvp_status.toLowerCase();\n filtered = filtered.filter((g: any) =>\n (g.rsvp_status || \"\").toLowerCase() === s\n );\n }\n if (input.side) {\n const s = input.side.toLowerCase();\n filtered = filtered.filter((g: any) =>\n (g.side || \"\").toLowerCase() === s\n );\n }\n if (input.tier) {\n filtered = filtered.filter((g: any) => g.tier === input.tier);\n }\n return JSON.stringify({\n guests: filtered,\n count: filtered.length,\n total_in_list: guests.length,\n });\n }\n\n case \"add_guest\": {\n const rows = await readRange(\"Guests!A:A\", false, WEDDING_SHEET_ID);\n const existingIds = rows.slice(1).map((r) => r[0] || \"\").filter((s) =>\n s.startsWith(\"G\")\n );\n const maxNum = existingIds.length\n ? Math.max(...existingIds.map((id) => parseInt(id.slice(1)) || 0))\n : 0;\n const newId = `G${(maxNum + 1).toString().padStart(3, \"0\")}`;\n // Order: id, name, side, relationship, tier, email, phone, address, plus_one_allowed, plus_one_name, save_the_date_sent, invite_sent, rsvp_status, rsvp_date, dietary, song_request, table, notes\n const row = [\n newId,\n input.name,\n input.side || \"\",\n input.relationship || \"\",\n input.tier || \"B\",\n input.email || \"\",\n input.phone || \"\",\n \"\", // address\n input.plus_one_allowed ? \"TRUE\" : \"FALSE\",\n input.plus_one_name || \"\",\n \"FALSE\", // save_the_date_sent\n \"FALSE\", // invite_sent\n \"pending\", // rsvp_status\n \"\", // rsvp_date\n \"\", // dietary\n \"\", // song_request\n \"\", // table\n input.notes || \"\",\n ];\n await appendRow(WEDDING_SHEET_ID, \"Guests!A:R\", row);\n return JSON.stringify({ success: true, id: newId, guest: input.name });\n }\n\n case \"update_rsvp\": {\n const rows = await readRange(\"Guests!A:R\", false, WEDDING_SHEET_ID);\n if (rows.length < 2) {\n return JSON.stringify({ success: false, reason: \"no guests\" });\n }\n const query = (input.guest_id_or_name || \"\").toLowerCase();\n let rowIdx = -1;\n for (let i = 1; i < rows.length; i++) {\n const id = (rows[i][0] || \"\").toLowerCase();\n const name = (rows[i][1] || \"\").toLowerCase();\n if (id === query || name === query || name.includes(query)) {\n rowIdx = i;\n break;\n }\n }\n if (rowIdx === -1) {\n return JSON.stringify({\n success: false,\n reason: `no guest matched \"${input.guest_id_or_name}\"`,\n });\n }\n const updated = [...rows[rowIdx]];\n const today = new Date().toISOString().slice(0, 10);\n updated[12] = input.rsvp_status; // rsvp_status\n updated[13] = today; // rsvp_date\n if (input.plus_one_name) updated[9] = input.plus_one_name;\n if (input.dietary) updated[14] = input.dietary;\n if (input.song_request) updated[15] = input.song_request;\n if (input.notes) {\n const existing = updated[17] || \"\";\n updated[17] = existing\n ? `${today}: ${input.notes} | ${existing}`\n : input.notes;\n }\n const sheetRow = rowIdx + 1;\n await updateRow(\n WEDDING_SHEET_ID,\n `Guests!A${sheetRow}:R${sheetRow}`,\n updated,\n );\n return JSON.stringify({\n success: true,\n guest: rows[rowIdx][1],\n rsvp: input.rsvp_status,\n });\n }\n\n case \"log_wedding_decision\": {\n const rows = await readRange(\"Decisions!A:A\", false, WEDDING_SHEET_ID);\n const existingIds = rows.slice(1).map((r) => r[0] || \"\").filter((s) =>\n s.startsWith(\"D\")\n );\n const maxNum = existingIds.length\n ? Math.max(...existingIds.map((id) => parseInt(id.slice(1)) || 0))\n : 0;\n const newId = `D${(maxNum + 1).toString().padStart(3, \"0\")}`;\n // Order: id, date, decision, category, notes, superseded_by\n const today = new Date().toISOString().slice(0, 10);\n const row = [\n newId,\n today,\n input.decision,\n input.category || \"\",\n input.notes || \"\",\n \"\",\n ];\n await appendRow(WEDDING_SHEET_ID, \"Decisions!A:F\", row);\n return JSON.stringify({\n success: true,\n id: newId,\n decision: input.decision,\n });\n }\n\n case \"get_wedding_budget_summary\": {\n // Read both Vendors and Budget tabs in parallel\n const [vendorRows, budgetRows] = await Promise.all([\n readRange(\"Vendors!A:O\", true, WEDDING_SHEET_ID),\n readRange(\"Budget!A:H\", true, WEDDING_SHEET_ID),\n ]);\n let totalQuoted = 0, totalPaid = 0, totalRemaining = 0;\n const vendorBreakdown: any[] = [];\n for (let i = 1; i < vendorRows.length; i++) {\n const r = vendorRows[i];\n if (!r[0]) continue;\n const quoted = parseFloat(r[7] || \"0\") || 0;\n const paid = parseFloat(r[8] || \"0\") || 0;\n const remaining = parseFloat(r[9] || \"0\") || 0;\n totalQuoted += quoted;\n totalPaid += paid;\n totalRemaining += remaining;\n if (quoted || paid || remaining) {\n vendorBreakdown.push({\n category: r[1],\n name: r[2],\n status: r[6],\n quoted,\n paid,\n remaining,\n });\n }\n }\n let totalEstimated = 0;\n for (let i = 1; i < budgetRows.length; i++) {\n const est = parseFloat(budgetRows[i][3] || \"0\") || 0;\n totalEstimated += est;\n }\n return JSON.stringify({\n total_estimated: totalEstimated,\n total_quoted: totalQuoted,\n total_paid: totalPaid,\n total_remaining: totalRemaining,\n vendor_breakdown: vendorBreakdown,\n });\n }\n\n case \"search_gmail\": {\n const max = Math.min(input.max_results || 10, 25);\n const messages = await gmailSearch(input.query, max);\n return JSON.stringify({ results: messages, count: messages.length });\n }\n\n case \"read_email\": {\n const msg = await gmailReadMessage(input.message_id);\n return JSON.stringify(msg);\n }\n\n case \"read_email_thread\": {\n const messages = await gmailReadThread(input.thread_id);\n return JSON.stringify({ thread_id: input.thread_id, messages });\n }\n\n case \"create_email_draft\": {\n const draft = await gmailCreateDraft(\n input.to,\n input.subject,\n input.body,\n input.thread_id,\n );\n return JSON.stringify({\n success: true,\n draft_id: draft.id,\n message:\n \"Draft saved to your Gmail Drafts folder. Review and send manually.\",\n });\n }\n\n case \"delete_wedding_row\": {\n const tab = input.tab;\n const query = (input.id_or_name || \"\").toLowerCase().trim();\n if (!query) {\n return JSON.stringify({\n success: false,\n reason: \"no id_or_name provided\",\n });\n }\n // Read tab to find the row\n const rows = await readRange(`${tab}!A:Z`, false, WEDDING_SHEET_ID);\n if (rows.length < 2) {\n return JSON.stringify({\n success: false,\n reason: `${tab} tab is empty or only has headers`,\n });\n }\n let rowIdx = -1;\n let matchedText = \"\";\n for (let i = 1; i < rows.length; i++) {\n // Check column A (id) and column B (name/decision/category) for match\n const colA = (rows[i][0] || \"\").toLowerCase();\n const colB = (rows[i][1] || \"\").toLowerCase();\n const colC = (rows[i][2] || \"\").toLowerCase();\n if (\n colA === query || colB === query || colC === query ||\n colA.includes(query) || colB.includes(query) || colC.includes(query)\n ) {\n rowIdx = i;\n matchedText = `${rows[i][0] || \"\"} - ${rows[i][1] || \"\"} - ${\n rows[i][2] || \"\"\n }`.trim();\n break;\n }\n }\n if (rowIdx === -1) {\n return JSON.stringify({\n success: false,\n reason: `no row in ${tab} matched \"${input.id_or_name}\"`,\n });\n }\n await deleteSheetRow(WEDDING_SHEET_ID, tab, rowIdx);\n return JSON.stringify({\n success: true,\n deleted_from: tab,\n deleted_row: matchedText,\n });\n }\n\n case \"clear_wedding_tab\": {\n const deleted = await clearSheetData(WEDDING_SHEET_ID, input.tab);\n return JSON.stringify({\n success: true,\n tab: input.tab,\n rows_deleted: deleted,\n });\n }\n\n default:\n return `Unknown tool: ${name}`;\n }\n}\n\n// ============================================================\n// AGENT LOOP\n// ============================================================\nconst SYSTEM_PROMPT =\n `You are Neesha's personal assistant and chief of staff via Telegram. She is a Kellogg MBA grad (June 2026), job searching for AI operator roles in SF, wedding in June, training for Hood to Coast on August 29, 2026. Today is ${\n new Date().toDateString()\n }.\n\nYou have access to tools to:\n- Manage her todos (Supabase) — for actionable things she needs to do\n- Log runs to her Hood to Coast training sheet\n- Manage her wedding planning sheet — vendors, guests, RSVPs, decisions, budget\n- Generate her daily briefing on demand (web search + synthesis)\n- Search and read her Gmail; create email drafts (saved to Drafts, never auto-sent)\n- Search the web\n\nARCHITECTURE — what goes where:\n- Todos = \"things I need to do\" (find a florist, prep for interview, follow up with X). Goes in Supabase via add_todo.\n- Wedding sheet = structured backend (vendor records with quotes/contracts/status, guest list with RSVPs, major decisions, budget). Use the wedding tools.\n- Hood to Coast sheet = training plan + run log.\n- Gmail = source of truth for vendor contracts, invoices, guest contact info, professional correspondence. Search it when she asks for contract details, invoice amounts, vendor contacts, or thread context. Use create_email_draft for outgoing emails — never auto-send.\n- These don't overlap. Don't write a vendor as a todo. Don't write a todo as a vendor entry.\n\nEMAIL WORKFLOW:\n- When she asks about a vendor's details (cost, contact info, contract terms), search Gmail first, then optionally write findings to the wedding sheet.\n- When she asks to draft an email, use create_email_draft. Match her voice: direct, warm, no fluff, no emojis. Show her the draft body in your reply so she can verify before opening Gmail.\n- Drafts are NEVER auto-sent. Always tell her \"draft saved to Gmail — review and send when ready.\"\n\nDESTRUCTIVE ACTIONS (delete_wedding_row, clear_wedding_tab):\n- ALWAYS describe what will be deleted and ask for explicit confirmation before calling these tools.\n- Example flow: User: \"delete the dummy florist\". You: \"I'll delete V001 - florist - Bloom & Co. Confirm?\" Wait for \"yes\" before calling delete_wedding_row.\n- For clear_wedding_tab, count the rows first by listing them: \"I'll clear all 5 rows from Vendors. Confirm?\"\n- If she says \"delete it\" without specifying which one and there's ambiguity, ask which row before doing anything.\n\nGUIDELINES:\n- Be direct, warm, concise. She reads on her phone. Plain text, no markdown headers, no bullet lists unless she asks. Max ~150 words for most replies.\n- For run logging: when she describes a run, parse details and ASK HER TO CONFIRM. Only call log_run AFTER explicit yes/confirm. After logging, give brief coach feedback with weekly context.\n- For wedding vendor/guest writes: don't ask for confirmation, just do it and confirm it was done. These are quick captures, not high-stakes.\n- For todos: just add them.\n- For coaching feedback: be specific. Reference the Guide if relevant.\n- For briefing: when she says \"give me my briefing,\" \"what's the news,\" \"catch me up\" — call get_daily_briefing. Tell her it'll take 10-15 sec.\n- If she's preparing for a job interview, be a smart sounding board. Don't be sycophantic. Push back when wrong.\n- If she's venting or chatting, just chat. Don't force tools.\n\nCONFIRMATION FLOW for runs:\n1. User describes a run\n2. You parse and reply: \"Got it — confirm: {summary}? Reply yes to log.\"\n3. If next message is yes, NOW call log_run\n4. If no/cancel, acknowledge and don't log\n5. After logging, brief coach feedback with weekly context`;\n\nasync function runAgent(\n chatId: number,\n userMessage: string,\n conversationHistory: any[] = [],\n): Promise<{ reply: string; newMessages: any[] }> {\n const userMsgObj = { role: \"user\", content: userMessage };\n const messages = [...conversationHistory, userMsgObj];\n const newMessages: any[] = [userMsgObj]; // track what's new this turn for persistence\n const maxIterations = 8;\n\n for (let i = 0; i < maxIterations; i++) {\n tgTyping(chatId);\n\n const res = await fetch(\"https://api.anthropic.com/v1/messages\", {\n method: \"POST\",\n headers: {\n \"x-api-key\": ANTHROPIC_KEY,\n \"anthropic-version\": \"2023-06-01\",\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({\n model: \"claude-haiku-4-5-20251001\",\n max_tokens: 1500,\n system: SYSTEM_PROMPT,\n tools: TOOLS,\n messages,\n }),\n });\n\n if (!res.ok) {\n const err = await res.text();\n throw new Error(`claude ${res.status}: ${err}`);\n }\n const data = await res.json();\n\n // Save FULL content array (includes tool_use blocks) — critical for continuity\n const assistantMsg = { role: \"assistant\", content: data.content };\n messages.push(assistantMsg);\n newMessages.push(assistantMsg);\n\n // If Claude wants to use tools, execute them (in parallel when multiple)\n if (data.stop_reason === \"tool_use\") {\n const toolUseBlocks = data.content.filter((b: any) =>\n b.type === \"tool_use\"\n );\n\n const toolResults = await Promise.all(\n toolUseBlocks.map(async (block: any) => {\n try {\n const result = await executeTool(block.name, block.input);\n return {\n type: \"tool_result\",\n tool_use_id: block.id,\n content: result,\n };\n } catch (err: any) {\n return {\n type: \"tool_result\",\n tool_use_id: block.id,\n content: `Error: ${err.message}`,\n is_error: true,\n };\n }\n }),\n );\n\n const toolResultMsg = { role: \"user\", content: toolResults };\n messages.push(toolResultMsg);\n newMessages.push(toolResultMsg);\n continue; // loop back, let Claude decide what's next\n }\n\n // Claude is done — extract final text\n const textBlocks = data.content.filter((b: any) => b.type === \"text\");\n const reply = textBlocks.map((b: any) => b.text).join(\"\\n\").trim();\n return { reply, newMessages };\n }\n\n return { reply: \"I got stuck in a loop. Try rephrasing?\", newMessages };\n}\n\n// ============================================================\n// MAIN HANDLER\n// ============================================================\n\n// ============================================================\n// CONVERSATION PERSISTENCE (survives val cold starts)\n// ============================================================\n// History is stored in Supabase bot_conversations table.\n// We save FULL content arrays (including tool_use/tool_result blocks),\n// not just text — otherwise Claude can't see its own structured turns.\n\nconst HISTORY_TURNS = 8; // user+assistant message pairs to keep in context\n\nasync function loadHistory(chatId: number): Promise {\n // Fetch most recent N messages, oldest-first\n const limit = HISTORY_TURNS * 4; // generous to allow tool_use chains\n const rows = await sbFetch(\n `bot_conversations?chat_id=eq.${chatId}&order=created_at.desc&limit=${limit}`,\n );\n if (!rows || !rows.length) return [];\n // Reverse so oldest first\n let history = rows.reverse().map((r: any) => ({\n role: r.role,\n content: r.content,\n }));\n\n // Anthropic API requires:\n // - first message must be 'user'\n // - tool_use in assistant must be followed by tool_result in user\n // Trim from the start until we find a valid user message that doesn't start with tool_result\n while (history.length > 0) {\n const first = history[0];\n if (\n first.role === \"user\" && (typeof first.content === \"string\" ||\n !(Array.isArray(first.content) &&\n first.content[0]?.type === \"tool_result\"))\n ) {\n break;\n }\n history.shift();\n }\n\n // Trim from the end if last assistant message has unanswered tool_use\n while (history.length > 0) {\n const last = history[history.length - 1];\n if (\n last.role === \"assistant\" && Array.isArray(last.content) &&\n last.content.some((b: any) => b.type === \"tool_use\")\n ) {\n // Pending tool_use without result — drop it\n history.pop();\n continue;\n }\n break;\n }\n\n return history;\n}\n\nasync function saveTurn(\n chatId: number,\n role: \"user\" | \"assistant\",\n content: any,\n) {\n await sbFetch(\"bot_conversations\", {\n method: \"POST\",\n body: JSON.stringify({\n chat_id: chatId,\n role,\n content, // can be string OR array of content blocks (tool_use, tool_result, text, etc.)\n }),\n });\n}\n\nasync function pruneOldHistory(chatId: number) {\n // Keep only the most recent N messages per chat. Delete the rest.\n // We do this opportunistically (not every turn) to avoid extra requests.\n const keepCount = HISTORY_TURNS * 4; // generous upper bound to allow tool_use chains\n const all = await sbFetch(\n `bot_conversations?chat_id=eq.${chatId}&order=created_at.desc&select=id&offset=${keepCount}`,\n );\n if (all && all.length > 0) {\n const idsToDelete = all.map((r: any) => `\"${r.id}\"`).join(\",\");\n await sbFetch(`bot_conversations?id=in.(${idsToDelete})`, {\n method: \"DELETE\",\n });\n }\n}\n\nasync function clearHistory(chatId: number) {\n await sbFetch(`bot_conversations?chat_id=eq.${chatId}`, { method: \"DELETE\" });\n}\n\nexport default async function (req: Request): Promise {\n if (req.method !== \"POST\") return new Response(\"ok\");\n\n let update: any;\n try {\n update = await req.json();\n } catch {\n return new Response(\"ok\");\n }\n const msg = update.message;\n if (!msg) return new Response(\"ok\");\n if (String(msg.from.id) !== ALLOWED_USER) {\n await tgReply(msg.chat.id, \"not authorized\");\n return new Response(\"ok\");\n }\n\n // Voice → text\n let text = (msg.text || \"\").trim();\n if (msg.voice) {\n try {\n const audio = await downloadVoice(msg.voice.file_id);\n text = await transcribe(audio);\n if (!text) {\n await tgReply(msg.chat.id, \"couldn't hear that — try again?\");\n return new Response(\"ok\");\n }\n } catch (err: any) {\n await tgReply(msg.chat.id, `voice error: ${err.message}`);\n return new Response(\"ok\");\n }\n }\n if (!text) return new Response(\"ok\");\n\n if (text === \"/start\") {\n await tgReply(\n msg.chat.id,\n \"Hi. I'm your personal assistant. Send me todos, log runs, ask anything.\",\n );\n return new Response(\"ok\");\n }\n if (text === \"/reset\") {\n await clearHistory(msg.chat.id);\n await tgReply(msg.chat.id, \"Conversation reset.\");\n return new Response(\"ok\");\n }\n\n try {\n const history = await loadHistory(msg.chat.id);\n const { reply, newMessages } = await runAgent(msg.chat.id, text, history);\n // Persist all new messages from this turn (user + assistant + any tool exchanges)\n for (const m of newMessages) {\n await saveTurn(msg.chat.id, m.role, m.content);\n }\n // Opportunistic prune (don't await — fire and forget)\n pruneOldHistory(msg.chat.id).catch(() => {});\n await tgReply(msg.chat.id, reply);\n } catch (err: any) {\n await tgReply(msg.chat.id, `error: ${err.message}`);\n console.error(err);\n }\n\n return new Response(\"ok\");\n}","createdAt",["D",1777222624115],"branchVersion","branchId","e17d3c12-401f-11f1-b553-42b51c65c3df","id","e17c266a-401f-11f1-b553-42b51c65c3df","chief_of_staff_telegram",["D",1777064109635],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","imageUrl","287cc5f1-94fe-47e8-8d89-c07ff8d62810","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","019dbb61-cf69-70e0-8158-e726c56a1141","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_94":93,"_101":97},"org",{"_94":93,"_95":-5,"_96":97,"_18":54,"_98":99,"_100":25},"branch",{"_13":83,"_32":84,"_43":42,"_85":44,"_86":-5,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":45,"_92":93},"isOwned",16,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","neeshaenator","handle","displayName","avatar","","tier","free","canRestrictVals","profileImageUrl","branchName","adoptOrgId",{"_43":44,"_32":45,"_38":162,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":-5,"_53":-5,"_18":54,"_55":-5,"_56":25,"_57":-5,"_58":-5,"_59":60,"_61":62,"_63":-5,"_64":-5,"_65":-5,"_66":-5,"_67":68,"_69":68,"_70":71,"_72":71,"_73":71,"_74":68,"_75":68,"_76":163,"_78":164,"_80":165,"_82":25},"tree",[153,154],"files",[153,154],"counts",{"_141":60,"_142":143,"_144":60,"_145":146,"_147":148},"contents",[124,125],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles",true,"grants","orgs","customDomains",{},{"_43":137,"_32":28,"_30":31,"_129":-5,"_41":42,"_40":14,"_131":25,"_38":138,"_13":139,"_33":34,"_35":37,"_24":25,"_135":-5,"_27":140},{"_43":126,"_32":127,"_30":128,"_129":-5,"_41":42,"_40":130,"_131":119,"_38":132,"_13":133,"_33":34,"_35":134,"_24":25,"_135":-5,"_27":136},"dc2096ee-40f4-11f1-b8cd-42b51c65c3df","new-file-4454.ts","d1f68a16-40f4-11f1-8a06-42b51c65c3df","parentId",14,"latest",["D",1777155583436],3,"const GMAIL_CLIENT_ID = Deno.env.get(\"GMAIL_CLIENT_ID\")!;\nconst GMAIL_CLIENT_SECRET = Deno.env.get(\"GMAIL_CLIENT_SECRET\")!;\nconst GMAIL_REFRESH_TOKEN = Deno.env.get(\"GMAIL_REFRESH_TOKEN\")!;\n\nexport default async function (req: Request): Promise {\n try {\n // Step 1: refresh access token\n const tokenRes = await fetch(\"https://oauth2.googleapis.com/token\", {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/x-www-form-urlencoded\" },\n body: new URLSearchParams({\n client_id: GMAIL_CLIENT_ID,\n client_secret: GMAIL_CLIENT_SECRET,\n refresh_token: GMAIL_REFRESH_TOKEN,\n grant_type: \"refresh_token\",\n }).toString(),\n });\n\n if (!tokenRes.ok) {\n const errText = await tokenRes.text();\n return new Response(\n JSON.stringify(\n {\n step: \"auth_failed\",\n status: tokenRes.status,\n error: errText,\n env_check: {\n client_id_set: !!GMAIL_CLIENT_ID,\n client_id_prefix: GMAIL_CLIENT_ID?.slice(0, 20),\n client_secret_set: !!GMAIL_CLIENT_SECRET,\n refresh_token_set: !!GMAIL_REFRESH_TOKEN,\n refresh_token_prefix: GMAIL_REFRESH_TOKEN?.slice(0, 10),\n },\n },\n null,\n 2,\n ),\n { status: 500 },\n );\n }\n\n const tokenData = await tokenRes.json();\n const accessToken = tokenData.access_token;\n\n // Step 2: try to list 1 email\n const listRes = await fetch(\n \"https://gmail.googleapis.com/gmail/v1/users/me/messages?maxResults=1\",\n { headers: { Authorization: `Bearer ${accessToken}` } },\n );\n\n if (!listRes.ok) {\n const errText = await listRes.text();\n return new Response(\n JSON.stringify(\n {\n step: \"list_failed\",\n status: listRes.status,\n error: errText,\n },\n null,\n 2,\n ),\n { status: 500 },\n );\n }\n\n const listData = await listRes.json();\n return new Response(JSON.stringify(\n {\n step: \"success\",\n message_count_returned: listData.messages?.length || 0,\n first_message_id: listData.messages?.[0]?.id,\n },\n null,\n 2,\n ));\n } catch (err: any) {\n return new Response(\n JSON.stringify(\n {\n step: \"exception\",\n error: err.message,\n },\n null,\n 2,\n ),\n { status: 500 },\n );\n }\n}","label",[127],"f37cc6ae-4190-11f1-b2fc-42b51c65c3df",["D",1777222624115],10,[28],"pulls","branches",1,"forks","envVars",{"_149":151,"_152":60},"connections",{"_149":60,"_150":60},"count","unfilledCount",12,"emptyCount",{"_43":137,"_32":28,"_30":31,"_129":-5,"_41":42,"_40":14,"_131":25,"_38":159,"_13":139,"_33":34,"_35":37,"_24":25,"_135":-5,"_156":160,"_27":161},{"_43":126,"_32":127,"_30":128,"_129":-5,"_41":42,"_40":130,"_131":119,"_38":155,"_13":133,"_33":34,"_35":134,"_24":25,"_135":-5,"_156":157,"_27":158},["D",1777155583436],"children",[],[127],["D",1777222624115],[],[28],["D",1777064109635],{"_94":93,"_101":97},{"_94":93,"_95":-5,"_96":97,"_18":54,"_98":99,"_100":25},{"_13":83,"_32":84,"_43":42,"_85":44,"_86":-5,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":45,"_92":93},"ctx",{"_76":-5,"_121":199,"_200":201,"_202":203,"_204":25,"_205":25,"_206":25,"_207":119,"_208":-5,"_209":-7,"_210":-7,"_211":60,"_212":25,"_213":25,"_214":-5,"_215":25,"_216":25,"_217":25,"_218":-5},"ENV",{"_170":171,"_172":173,"_174":84,"_175":176,"_177":178,"_179":180,"_181":182,"_183":184,"_185":186,"_187":188,"_189":190,"_191":192,"_193":194,"_195":196,"_197":198},"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 · v15