[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_293":294,"_295":296},"routes/_app.x.$handle.$name",{"_11":12,"_13":14,"_15":16,"_234":79,"_48":-7,"_235":-5,"_17":236,"_237":238,"_239":240,"_241":242,"_243":244,"_62":-5,"_245":-5,"_246":-5,"_247":24,"_248":249,"_250":251,"_252":-5,"_253":-5,"_254":255},"routes/_app.x.$handle.$name.branch.$branch.history",{"_11":12,"_13":14,"_15":16,"_17":18,"_19":20,"_21":22,"_23":24,"_25":-5},"handle","neeshaenator","name","chief_of_staff_telegram","branchName","main","project",{"_42":188,"_13":14,"_46":189,"_190":-5,"_191":24,"_192":193,"_194":193,"_195":-5,"_196":-5,"_25":77,"_197":-5,"_198":24,"_199":-5,"_200":-5,"_201":20,"_50":51,"_202":-5,"_203":-5,"_204":-5,"_205":-5,"_206":207,"_208":207,"_209":210,"_211":210,"_212":210,"_213":207,"_214":207,"_60":215,"_216":217,"_218":219,"_220":24},"page",0,"history",[26,27,28,29,30,31,32,33,34,35,36,37,38,39,40,41],"hasNext",false,"userId",{"_42":181,"_44":45,"_46":182,"_48":183,"_50":51,"_52":174,"_53":-5,"_54":-5,"_55":-5,"_56":-5,"_57":-5,"_58":-5,"_59":-5,"_60":184,"_62":185,"_64":-5,"_65":-5,"_66":-5,"_67":-5,"_68":186},{"_42":174,"_44":45,"_46":175,"_48":176,"_50":51,"_52":167,"_53":-5,"_54":-5,"_55":-5,"_56":-5,"_57":-5,"_58":-5,"_59":-5,"_60":177,"_62":178,"_64":-5,"_65":-5,"_66":-5,"_67":-5,"_68":179},{"_42":167,"_44":45,"_46":168,"_48":169,"_50":51,"_52":160,"_53":-5,"_54":-5,"_55":-5,"_56":-5,"_57":-5,"_58":-5,"_59":-5,"_60":170,"_62":171,"_64":-5,"_65":-5,"_66":-5,"_67":-5,"_68":172},{"_42":160,"_44":45,"_46":161,"_48":162,"_50":51,"_52":153,"_53":-5,"_54":-5,"_55":-5,"_56":-5,"_57":-5,"_58":-5,"_59":-5,"_60":163,"_62":164,"_64":-5,"_65":-5,"_66":-5,"_67":-5,"_68":165},{"_42":153,"_44":45,"_46":154,"_48":155,"_50":51,"_52":144,"_53":-5,"_54":-5,"_55":-5,"_56":-5,"_57":-5,"_58":-5,"_59":-5,"_60":156,"_62":157,"_64":-5,"_65":-5,"_66":-5,"_67":-5,"_68":158},{"_42":144,"_44":45,"_46":145,"_48":146,"_50":51,"_52":137,"_53":-5,"_54":-5,"_55":-5,"_56":-5,"_57":-5,"_58":-5,"_59":-5,"_60":147,"_62":148,"_64":-5,"_65":-5,"_66":-5,"_67":-5,"_68":149},{"_42":137,"_44":45,"_46":138,"_48":139,"_50":51,"_52":130,"_53":-5,"_54":-5,"_55":-5,"_56":-5,"_57":-5,"_58":-5,"_59":-5,"_60":140,"_62":141,"_64":-5,"_65":-5,"_66":-5,"_67":-5,"_68":142},{"_42":130,"_44":45,"_46":131,"_48":132,"_50":51,"_52":123,"_53":-5,"_54":-5,"_55":-5,"_56":-5,"_57":-5,"_58":-5,"_59":-5,"_60":133,"_62":134,"_64":-5,"_65":-5,"_66":-5,"_67":-5,"_68":135},{"_42":123,"_44":45,"_46":124,"_48":125,"_50":51,"_52":116,"_53":-5,"_54":-5,"_55":-5,"_56":-5,"_57":-5,"_58":-5,"_59":-5,"_60":126,"_62":127,"_64":-5,"_65":-5,"_66":-5,"_67":-5,"_68":128},{"_42":116,"_44":45,"_46":117,"_48":118,"_50":51,"_52":109,"_53":-5,"_54":-5,"_55":-5,"_56":-5,"_57":-5,"_58":-5,"_59":-5,"_60":119,"_62":120,"_64":-5,"_65":-5,"_66":-5,"_67":-5,"_68":121},{"_42":109,"_44":45,"_46":110,"_48":111,"_50":51,"_52":102,"_53":-5,"_54":-5,"_55":-5,"_56":-5,"_57":-5,"_58":-5,"_59":-5,"_60":112,"_62":113,"_64":-5,"_65":-5,"_66":-5,"_67":-5,"_68":114},{"_42":102,"_44":45,"_46":103,"_48":104,"_50":51,"_52":95,"_53":-5,"_54":-5,"_55":-5,"_56":-5,"_57":-5,"_58":-5,"_59":-5,"_60":105,"_62":106,"_64":-5,"_65":-5,"_66":-5,"_67":-5,"_68":107},{"_42":95,"_44":45,"_46":96,"_48":97,"_50":51,"_52":87,"_53":-5,"_54":-5,"_55":-5,"_56":-5,"_57":-5,"_58":-5,"_59":-5,"_60":98,"_62":99,"_64":-5,"_65":-5,"_66":-5,"_67":-5,"_68":100},{"_42":87,"_44":45,"_46":88,"_48":89,"_50":51,"_52":80,"_53":-5,"_54":-5,"_55":-5,"_56":-5,"_57":-5,"_58":-5,"_59":-5,"_60":90,"_62":91,"_64":-5,"_65":-5,"_66":-5,"_67":-5,"_68":92},{"_42":80,"_44":45,"_46":81,"_48":82,"_50":51,"_52":43,"_53":-5,"_54":-5,"_55":-5,"_56":-5,"_57":-5,"_58":-5,"_59":-5,"_60":83,"_62":84,"_64":-5,"_65":-5,"_66":-5,"_67":-5,"_68":85},{"_42":43,"_44":45,"_46":47,"_48":49,"_50":51,"_52":-5,"_53":-5,"_54":-5,"_55":-5,"_56":-5,"_57":-5,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":-5,"_65":-5,"_66":-5,"_67":-5,"_68":69},"id","e18e211c-401f-11f1-b553-42b51c65c3df","branchId","e17d3c12-401f-11f1-b553-42b51c65c3df","createdAt",["D",1777064109659],"version",1,"orgId","019dbb61-cf69-70e0-8158-e726c56a1141","parentId","incomingCommitId","aiChatMessageId","aiChatThreadId","aiChatThreadUserId","aiChatThreadTitle","source","clientLabel","user",{"_42":77,"_50":51,"_11":12,"_78":79},"file",{"_71":72,"_13":73,"_74":75,"_76":24},"pull","merge","revert","multiple","commits",[70],{"_42":43,"_44":45,"_46":47,"_48":49,"_50":51,"_52":-5,"_53":-5,"_54":-5,"_55":-5,"_56":-5,"_57":-5,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":-5,"_65":-5,"_66":-5},"fileId","e18331bc-401f-11f1-b553-42b51c65c3df","main.ts","fileType","script","deleted","287cc5f1-94fe-47e8-8d89-c07ff8d62810","avatar","","e8b325dc-401f-11f1-8d19-42b51c65c3df",["D",1777064121689],2,{"_42":77,"_50":51,"_11":12,"_78":79},{"_71":72,"_13":73,"_74":75,"_76":24},[86],{"_42":80,"_44":45,"_46":81,"_48":82,"_50":51,"_52":43,"_53":-5,"_54":-5,"_55":-5,"_56":-5,"_57":-5,"_58":-5,"_59":-5,"_60":83,"_62":84,"_64":-5,"_65":-5,"_66":-5},"e8bcbb1a-401f-11f1-ae0d-42b51c65c3df",["D",1777064121690],3,{"_42":77,"_50":51,"_11":12,"_78":79},{"_71":72,"_13":73,"_74":94,"_76":24},[93],{"_42":87,"_44":45,"_46":88,"_48":89,"_50":51,"_52":80,"_53":-5,"_54":-5,"_55":-5,"_56":-5,"_57":-5,"_58":-5,"_59":-5,"_60":90,"_62":91,"_64":-5,"_65":-5,"_66":-5},"http","f98525d6-401f-11f1-a53b-42b51c65c3df",["D",1777064149927],4,{"_42":77,"_50":51,"_11":12,"_78":79},{"_71":72,"_13":73,"_74":94,"_76":24},[101],{"_42":95,"_44":45,"_46":96,"_48":97,"_50":51,"_52":87,"_53":-5,"_54":-5,"_55":-5,"_56":-5,"_57":-5,"_58":-5,"_59":-5,"_60":98,"_62":99,"_64":-5,"_65":-5,"_66":-5},"d7771c2c-4021-11f1-9666-42b51c65c3df",["D",1777064951753],5,{"_42":77,"_50":51,"_11":12,"_78":79},{"_71":72,"_13":73,"_74":94,"_76":24},[108],{"_42":102,"_44":45,"_46":103,"_48":104,"_50":51,"_52":95,"_53":-5,"_54":-5,"_55":-5,"_56":-5,"_57":-5,"_58":-5,"_59":-5,"_60":105,"_62":106,"_64":-5,"_65":-5,"_66":-5},"a0c126a4-4022-11f1-a925-42b51c65c3df",["D",1777065289486],6,{"_42":77,"_50":51,"_11":12,"_78":79},{"_71":72,"_13":73,"_74":94,"_76":24},[115],{"_42":109,"_44":45,"_46":110,"_48":111,"_50":51,"_52":102,"_53":-5,"_54":-5,"_55":-5,"_56":-5,"_57":-5,"_58":-5,"_59":-5,"_60":112,"_62":113,"_64":-5,"_65":-5,"_66":-5},"aaeaed2a-40dd-11f1-bc7a-42b51c65c3df",["D",1777145622398],7,{"_42":77,"_50":51,"_11":12,"_78":79},{"_71":72,"_13":73,"_74":94,"_76":24},[122],{"_42":116,"_44":45,"_46":117,"_48":118,"_50":51,"_52":109,"_53":-5,"_54":-5,"_55":-5,"_56":-5,"_57":-5,"_58":-5,"_59":-5,"_60":119,"_62":120,"_64":-5,"_65":-5,"_66":-5},"f1212344-40de-11f1-8f8b-42b51c65c3df",["D",1777146169723],8,{"_42":77,"_50":51,"_11":12,"_78":79},{"_71":72,"_13":73,"_74":94,"_76":24},[129],{"_42":123,"_44":45,"_46":124,"_48":125,"_50":51,"_52":116,"_53":-5,"_54":-5,"_55":-5,"_56":-5,"_57":-5,"_58":-5,"_59":-5,"_60":126,"_62":127,"_64":-5,"_65":-5,"_66":-5},"ec9fe1ae-40e1-11f1-b0cd-42b51c65c3df",["D",1777147450631],9,{"_42":77,"_50":51,"_11":12,"_78":79},{"_71":72,"_13":73,"_74":94,"_76":24},[136],{"_42":130,"_44":45,"_46":131,"_48":132,"_50":51,"_52":123,"_53":-5,"_54":-5,"_55":-5,"_56":-5,"_57":-5,"_58":-5,"_59":-5,"_60":133,"_62":134,"_64":-5,"_65":-5,"_66":-5},"cd7021a6-40f3-11f1-a27c-42b51c65c3df",["D",1777155129251],10,{"_42":77,"_50":51,"_11":12,"_78":79},{"_71":72,"_13":73,"_74":94,"_76":24},[143],{"_42":137,"_44":45,"_46":138,"_48":139,"_50":51,"_52":130,"_53":-5,"_54":-5,"_55":-5,"_56":-5,"_57":-5,"_58":-5,"_59":-5,"_60":140,"_62":141,"_64":-5,"_65":-5,"_66":-5},"d1f87d6c-40f4-11f1-8a06-42b51c65c3df",["D",1777155566389],11,{"_42":77,"_50":51,"_11":12,"_78":79},{"_71":151,"_13":152,"_74":75,"_76":24},[150],{"_42":144,"_44":45,"_46":145,"_48":146,"_50":51,"_52":137,"_53":-5,"_54":-5,"_55":-5,"_56":-5,"_57":-5,"_58":-5,"_59":-5,"_60":147,"_62":148,"_64":-5,"_65":-5,"_66":-5},"d1f68a16-40f4-11f1-8a06-42b51c65c3df","new-file-4454.ts","d4f15142-40f4-11f1-93ab-42b51c65c3df",["D",1777155570949],12,{"_42":77,"_50":51,"_11":12,"_78":79},{"_71":151,"_13":152,"_74":75,"_76":24},[159],{"_42":153,"_44":45,"_46":154,"_48":155,"_50":51,"_52":144,"_53":-5,"_54":-5,"_55":-5,"_56":-5,"_57":-5,"_58":-5,"_59":-5,"_60":156,"_62":157,"_64":-5,"_65":-5,"_66":-5},"d51037ec-40f4-11f1-aba9-42b51c65c3df",["D",1777155570975],13,{"_42":77,"_50":51,"_11":12,"_78":79},{"_71":151,"_13":152,"_74":94,"_76":24},[166],{"_42":160,"_44":45,"_46":161,"_48":162,"_50":51,"_52":153,"_53":-5,"_54":-5,"_55":-5,"_56":-5,"_57":-5,"_58":-5,"_59":-5,"_60":163,"_62":164,"_64":-5,"_65":-5,"_66":-5},"dc22d92c-40f4-11f1-b8cd-42b51c65c3df",["D",1777155583436],14,{"_42":77,"_50":51,"_11":12,"_78":79},{"_71":151,"_13":152,"_74":94,"_76":24},[173],{"_42":167,"_44":45,"_46":168,"_48":169,"_50":51,"_52":160,"_53":-5,"_54":-5,"_55":-5,"_56":-5,"_57":-5,"_58":-5,"_59":-5,"_60":170,"_62":171,"_64":-5,"_65":-5,"_66":-5},"f3802c54-4190-11f1-b2fc-42b51c65c3df",["D",1777222624115],15,{"_42":77,"_50":51,"_11":12,"_78":79},{"_71":72,"_13":73,"_74":94,"_76":24},[180],{"_42":174,"_44":45,"_46":175,"_48":176,"_50":51,"_52":167,"_53":-5,"_54":-5,"_55":-5,"_56":-5,"_57":-5,"_58":-5,"_59":-5,"_60":177,"_62":178,"_64":-5,"_65":-5,"_66":-5},"e34fd1c2-4519-11f1-96cf-42b51c65c3df",["D",1777611291486],16,{"_42":77,"_50":51,"_11":12,"_78":79},{"_71":72,"_13":73,"_74":94,"_76":24},[187],{"_42":181,"_44":45,"_46":182,"_48":183,"_50":51,"_52":174,"_53":-5,"_54":-5,"_55":-5,"_56":-5,"_57":-5,"_58":-5,"_59":-5,"_60":184,"_62":185,"_64":-5,"_65":-5,"_66":-5},"e17c266a-401f-11f1-b553-42b51c65c3df",["D",1777064109635],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","imageUrl","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm",{"_11":12,"_233":79},"org",{"_11":12,"_229":-5,"_78":79,"_25":77,"_230":231,"_232":24},"branch",{"_48":183,"_13":16,"_42":45,"_221":188,"_222":-5,"_223":-5,"_224":-5,"_225":-5,"_226":-5,"_227":14,"_228":12},"isOwned","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","tier","free","canRestrictVals","profileImageUrl","path","adoptOrgId",{"_42":188,"_13":14,"_46":289,"_190":-5,"_191":24,"_192":193,"_194":193,"_195":-5,"_196":-5,"_25":77,"_197":-5,"_198":24,"_199":-5,"_200":-5,"_201":20,"_50":51,"_202":-5,"_203":-5,"_204":-5,"_205":-5,"_206":207,"_208":207,"_209":210,"_211":210,"_212":210,"_213":207,"_214":207,"_60":290,"_216":291,"_218":292,"_220":24},"tree",[280,281],"files",[280,281],"counts",{"_270":20,"_271":49,"_272":20,"_273":274,"_275":276},"contents",[256,257],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles",true,"grants","orgs","customDomains",{},{"_42":266,"_13":73,"_71":72,"_52":-5,"_44":45,"_259":183,"_260":251,"_46":267,"_48":146,"_74":94,"_262":268,"_76":24,"_264":-5,"_234":269},{"_42":258,"_13":152,"_71":151,"_52":-5,"_44":45,"_259":169,"_260":251,"_46":261,"_48":89,"_74":94,"_262":263,"_76":24,"_264":-5,"_234":265},"dc2096ee-40f4-11f1-b8cd-42b51c65c3df","branchVersion","latest",["D",1777155583436],"content","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",[152],"e34bb6fa-4519-11f1-96cf-42b51c65c3df",["D",1777611291486],"// Personal assistant bot — agentic version with tool use\n// Drop-in replacement for telegram-bot-h2c.ts. Same env vars.\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 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; // running data — changes daily\nconst WEDDING_CACHE_TTL_MS = 30 * 60_000; // wedding data — changes weekly\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 const ttl = sheetId === WEDDING_SHEET_ID ? WEDDING_CACHE_TTL_MS : CACHE_TTL_MS;\n sheetCache.set(cacheKey, { data, expiresAt: Date.now() + ttl });\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 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\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\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 for (const k of sheetCache.keys()) {\n if (k.startsWith(`${spreadsheetId}:`)) sheetCache.delete(k);\n }\n return await res.json();\n}\n\nasync function clearSheetData(\n spreadsheetId: string,\n tabName: string,\n): Promise {\n const token = await getGoogleToken();\n const gid = await getSheetGid(spreadsheetId, tabName);\n const data = await readRange(`${tabName}!A:A`, false, spreadsheetId);\n const rowCount = data.length;\n if (rowCount <= 1) return 0;\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,\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;\n}\n\n// ---------- Gmail auth ----------\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 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 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 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),\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 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 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 ----------\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 {\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 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 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 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 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 name: \"list_guests\",\n description:\n \"List wedding guests. ALWAYS pass a filter (rsvp_status, side, or tier) when possible — there are 200+ guests and an unfiltered list will return only a summary. Filter by RSVP status (pending, yes, no, maybe), side (Neesha, Tony), or tier (A, B, C).\",\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 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 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 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 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);\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 const [logRows, planRow] = await Promise.all([\n readRange(`Bot Log!A5:I1000`),\n readRange(`Plan!A${4 + week}:K${4 + week}`, true),\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);\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 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 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\",\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 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])\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 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 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 \"\",\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 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 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 (\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;\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 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\n // Guard against returning the full 220-guest list — return summary instead\n if (filtered.length > 50 && !input.rsvp_status && !input.side && !input.tier) {\n return JSON.stringify({\n count: filtered.length,\n summary: \"Too many guests to list at once. Filter by rsvp_status, side, or tier.\",\n rsvp_breakdown: {\n yes: filtered.filter((g: any) => (g.rsvp_status || \"\").toLowerCase() === \"yes\").length,\n no: filtered.filter((g: any) => (g.rsvp_status || \"\").toLowerCase() === \"no\").length,\n maybe: filtered.filter((g: any) => (g.rsvp_status || \"\").toLowerCase() === \"maybe\").length,\n pending: filtered.filter((g: any) => (g.rsvp_status || \"\").toLowerCase() === \"pending\").length,\n },\n side_breakdown: {\n neesha: filtered.filter((g: any) => (g.side || \"\").toLowerCase() === \"neesha\").length,\n tony: filtered.filter((g: any) => (g.side || \"\").toLowerCase() === \"tony\").length,\n },\n tier_breakdown: {\n A: filtered.filter((g: any) => g.tier === \"A\").length,\n B: filtered.filter((g: any) => g.tier === \"B\").length,\n C: filtered.filter((g: any) => g.tier === \"C\").length,\n },\n });\n }\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 const row = [\n newId,\n input.name,\n input.side || \"\",\n input.relationship || \"\",\n input.tier || \"B\",\n input.email || \"\",\n input.phone || \"\",\n \"\",\n input.plus_one_allowed ? \"TRUE\" : \"FALSE\",\n input.plus_one_name || \"\",\n \"FALSE\",\n \"FALSE\",\n \"pending\",\n \"\",\n \"\",\n \"\",\n \"\",\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;\n updated[13] = today;\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 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 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 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 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];\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 const assistantMsg = { role: \"assistant\", content: data.content };\n messages.push(assistantMsg);\n newMessages.push(assistantMsg);\n\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 // Live message — full results for this turn's reasoning\n const toolResultMsg = { role: \"user\", content: toolResults };\n messages.push(toolResultMsg);\n\n // Persisted message — truncated to keep history lean\n const TOOL_RESULT_MAX_CHARS = 2000;\n const truncatedResults = toolResults.map((r: any) => {\n const content = typeof r.content === \"string\"\n ? r.content\n : JSON.stringify(r.content);\n if (content.length <= TOOL_RESULT_MAX_CHARS) return r;\n return {\n ...r,\n content: content.slice(0, TOOL_RESULT_MAX_CHARS) +\n `\\n[truncated — ${content.length - TOOL_RESULT_MAX_CHARS} more chars]`,\n };\n });\n newMessages.push({ role: \"user\", content: truncatedResults });\n continue;\n }\n\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// CONVERSATION PERSISTENCE\n// ============================================================\nconst HISTORY_TOKEN_BUDGET = 15000; // input tokens of history; leaves headroom under 50k TPM\nconst HISTORY_FETCH_LIMIT = 60; // upper bound on messages to consider\n\n// Rough token estimate: ~4 chars/token\nfunction estimateTokens(content: any): number {\n const str = typeof content === \"string\" ? content : JSON.stringify(content);\n return Math.ceil(str.length / 4);\n}\n\nasync function loadHistory(chatId: number): Promise {\n const rows = await sbFetch(\n `bot_conversations?chat_id=eq.${chatId}&order=created_at.desc&limit=${HISTORY_FETCH_LIMIT}`,\n );\n if (!rows || !rows.length) return [];\n\n // Walk newest→oldest, accumulating tokens until budget hit\n let tokens = 0;\n const kept: any[] = [];\n for (const r of rows) {\n const msgTokens = estimateTokens(r.content);\n if (tokens + msgTokens > HISTORY_TOKEN_BUDGET) break;\n tokens += msgTokens;\n kept.push({ role: r.role, content: r.content });\n }\n\n // Reverse to chronological order\n let history = kept.reverse();\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 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 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 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,\n }),\n });\n}\n\nasync function pruneOldHistory(chatId: number) {\n const keepCount = HISTORY_FETCH_LIMIT;\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\n// ============================================================\n// MAIN HANDLER\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 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 for (const m of newMessages) {\n await saveTurn(msg.chat.id, m.role, m.content);\n }\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}",[73],"pulls","branches","forks","envVars",{"_277":155,"_279":20},"connections",{"_277":20,"_278":20},"count","unfilledCount","emptyCount",{"_42":266,"_13":73,"_71":72,"_52":-5,"_44":45,"_259":183,"_260":251,"_46":286,"_48":146,"_74":94,"_262":268,"_76":24,"_264":-5,"_283":287,"_234":288},{"_42":258,"_13":152,"_71":151,"_52":-5,"_44":45,"_259":169,"_260":251,"_46":282,"_48":89,"_74":94,"_262":263,"_76":24,"_264":-5,"_283":284,"_234":285},["D",1777155583436],"children",[],[152],["D",1777611291486],[],[73],["D",1777064109635],{"_11":12,"_233":79},{"_11":12,"_229":-5,"_78":79,"_25":77,"_230":231,"_232":24},{"_48":183,"_13":16,"_42":45,"_221":188,"_222":-5,"_223":-5,"_224":-5,"_225":-5,"_226":-5,"_227":14,"_228":12},"ctx",{"_60":-5,"_253":326,"_327":328,"_329":330,"_331":24,"_332":24,"_333":24,"_334":251,"_335":-5,"_336":-7,"_337":-7,"_338":20,"_339":24,"_340":24,"_341":-5,"_342":24,"_343":24,"_344":24,"_345":-5},"ENV",{"_297":298,"_299":300,"_301":16,"_302":303,"_304":305,"_306":307,"_308":309,"_310":311,"_312":313,"_314":315,"_316":317,"_318":319,"_320":321,"_322":323,"_324":325},"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"]