[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_172":173,"_174":175},"routes/_app.x.$handle.$name",{"_100":99,"_32":45,"_108":90,"_27":109,"_13":14,"_110":-5,"_11":111,"_112":113,"_114":115,"_116":117,"_118":119,"_20":-5,"_120":-5,"_121":-5,"_122":25,"_123":124,"_125":59,"_126":-5,"_127":-5,"_128":129},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_43":44,"_32":45,"_38":46,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":57,"_58":59,"_60":-5,"_61":-5,"_62":63,"_64":65,"_66":67,"_68":69,"_70":71,"_72":-5,"_73":74,"_75":74,"_76":77,"_78":77,"_79":77,"_80":74,"_81":74,"_82":83,"_84":85,"_86":87,"_88":25},"version",21,"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","cron.ts","latestPath","fileId","bbeca6ca-aa52-11f1-b0ae-1607ee4eb77e","name","fileType","interval","content","// Family Manager Bot — Weekly Review Cron\n// Cron: 0 23 * * 0\n// Runs every Sunday at 7pm ET (23:00 UTC) and sends a weekly calendar preview.\n\nimport { blob } from \"https://esm.town/v/std/blob\";\n\nconst TELEGRAM_TOKEN = Deno.env.get(\"TELEGRAM_TOKEN\")!;\nconst GROUP_CHAT_ID = Deno.env.get(\"GROUP_CHAT_ID\")!;\n\nasync function getGoogleAccessToken(): Promise {\n let tokenData: any = await blob.getJSON(\"gcalToken\").catch(() => null);\n\n if (!tokenData) {\n const tokenJson = Deno.env.get(\"GOOGLE_TOKEN_JSON\");\n if (!tokenJson) return null;\n try {\n const raw = JSON.parse(atob(tokenJson));\n if (raw.accounts) {\n const accountId = raw.defaultAccount || Object.keys(raw.accounts)[0];\n tokenData = raw.accounts[accountId];\n } else {\n tokenData = raw;\n }\n } catch { return null; }\n }\n\n const accessToken: string | null = tokenData.access_token ?? tokenData.token ?? null;\n const refreshToken: string | null = tokenData.refresh_token ?? null;\n const expiryMs: number = tokenData.expiry_date\n ? (typeof tokenData.expiry_date === \"number\" ? tokenData.expiry_date : new Date(tokenData.expiry_date).getTime())\n : tokenData.expiry ? new Date(tokenData.expiry).getTime() : 0;\n\n if (expiryMs - Date.now() < 5 * 60 * 1000) {\n const credsJson = Deno.env.get(\"GOOGLE_CREDENTIALS_JSON\");\n if (!credsJson || !refreshToken) return accessToken;\n try {\n const creds = JSON.parse(atob(credsJson));\n const client = creds.installed || creds.web;\n const resp = await fetch(\"https://oauth2.googleapis.com/token\", {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/x-www-form-urlencoded\" },\n body: new URLSearchParams({ client_id: client.client_id, client_secret: client.client_secret, refresh_token: refreshToken, grant_type: \"refresh_token\" }),\n });\n const newToken = await resp.json();\n if (newToken.access_token) {\n const refreshed = { ...tokenData, access_token: newToken.access_token, token: newToken.access_token, expiry_date: Date.now() + (newToken.expires_in || 3600) * 1000 };\n await blob.setJSON(\"gcalToken\", refreshed);\n return newToken.access_token;\n }\n } catch { /* fall through */ }\n return accessToken;\n }\n return accessToken;\n}\n\nexport default async function () {\n if (!GROUP_CHAT_ID) return;\n\n const token = await getGoogleAccessToken();\n if (!token) { console.error(\"No Google access token\"); return; }\n\n const calendarId = encodeURIComponent(Deno.env.get(\"CALENDAR_ID\") || \"primary\");\n const now = new Date();\n const weekEnd = new Date(Date.now() + 7 * 86400000).toISOString();\n\n const resp = await fetch(\n `https://www.googleapis.com/calendar/v3/calendars/${calendarId}/events?timeMin=${now.toISOString()}&timeMax=${weekEnd}&maxResults=30&singleEvents=true&orderBy=startTime`,\n { headers: { Authorization: `Bearer ${token}` } },\n );\n const data = await resp.json();\n\n let message = `📅 *Weekly Preview*\\n_${now.toLocaleDateString(\"en-US\", { month: \"long\", day: \"numeric\", timeZone: \"America/New_York\" })} — next 7 days_\\n\\n`;\n\n if (!data.items?.length) {\n message += \"Nothing on the calendar this week! 🎉\";\n } else {\n const byDay: Record = {};\n for (const event of data.items) {\n const start = event.start?.dateTime || event.start?.date;\n const day = new Date(start).toLocaleDateString(\"en-US\", { weekday: \"long\", month: \"short\", day: \"numeric\", timeZone: \"America/New_York\" });\n if (!byDay[day]) byDay[day] = [];\n byDay[day].push(event);\n }\n for (const [day, events] of Object.entries(byDay)) {\n message += `*${day}*\\n`;\n for (const event of events) {\n const start = event.start?.dateTime || event.start?.date;\n const isAllDay = !event.start?.dateTime;\n const timeStr = isAllDay ? \"All day\" : new Date(start).toLocaleTimeString(\"en-US\", { hour: \"numeric\", minute: \"2-digit\", timeZone: \"America/New_York\" });\n message += ` • ${event.summary}${isAllDay ? \"\" : ` @ ${timeStr}`}\\n`;\n }\n message += \"\\n\";\n }\n }\n\n message += \"_Have a great week! 🌟_\";\n\n await fetch(`https://api.telegram.org/bot${TELEGRAM_TOKEN}/sendMessage`, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ chat_id: GROUP_CHAT_ID, text: message, parse_mode: \"Markdown\" }),\n });\n\n console.log(\"Weekly review sent\");\n}","// Family Manager Bot — Weekly Review Cron\n// Cron: 0 23 * * 0\n// Runs every Sunday at 7pm ET (23:00 UTC) and sends a weekly calendar preview.\n\nimport { blob } from \"https://esm.town/v/std/blob\";\n\nconst TELEGRAM_TOKEN = Deno.env.get(\"TELEGRAM_TOKEN\")!;\nconst GROUP_CHAT_ID = Deno.env.get(\"GROUP_CHAT_ID\")!;\n\nasync function getGoogleAccessToken(): Promise {\n let tokenData: any = await blob.getJSON(\"gcalToken\").catch(() => null);\n\n if (!tokenData) {\n const tokenJson = Deno.env.get(\"GOOGLE_TOKEN_JSON\");\n if (!tokenJson) return null;\n try {\n const raw = JSON.parse(atob(tokenJson));\n if (raw.accounts) {\n const accountId = raw.defaultAccount || Object.keys(raw.accounts)[0];\n tokenData = raw.accounts[accountId];\n } else {\n tokenData = raw;\n }\n } catch { return null; }\n }\n\n const accessToken: string | null = tokenData.access_token ?? tokenData.token ?? null;\n const refreshToken: string | null = tokenData.refresh_token ?? null;\n const expiryMs: number = tokenData.expiry_date\n ? (typeof tokenData.expiry_date === \"number\" ? tokenData.expiry_date : new Date(tokenData.expiry_date).getTime())\n : tokenData.expiry ? new Date(tokenData.expiry).getTime() : 0;\n\n if (expiryMs - Date.now() < 5 * 60 * 1000) {\n const credsJson = Deno.env.get(\"GOOGLE_CREDENTIALS_JSON\");\n if (!credsJson || !refreshToken) return accessToken;\n try {\n const creds = JSON.parse(atob(credsJson));\n const client = creds.installed || creds.web;\n const resp = await fetch(\"https://oauth2.googleapis.com/token\", {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/x-www-form-urlencoded\" },\n body: new URLSearchParams({ client_id: client.client_id, client_secret: client.client_secret, refresh_token: refreshToken, grant_type: \"refresh_token\" }),\n });\n const newToken = await resp.json();\n if (newToken.access_token) {\n const refreshed = { ...tokenData, access_token: newToken.access_token, token: newToken.access_token, expiry_date: Date.now() + (newToken.expires_in || 3600) * 1000 };\n await blob.setJSON(\"gcalToken\", refreshed);\n return newToken.access_token;\n }\n } catch { /* fall through */ }\n return accessToken;\n }\n return accessToken;\n}\n\nexport default async function () {\n if (!GROUP_CHAT_ID) return;\n\n const token = await getGoogleAccessToken();\n if (!token) { console.error(\"No Google access token\"); return; }\n\n const calendarId = encodeURIComponent(Deno.env.get(\"CALENDAR_ID\") || \"primary\");\n const now = new Date();\n const week1End = new Date(Date.now() + 7 * 86400000);\n const week2End = new Date(Date.now() + 14 * 86400000);\n\n // Fetch 2 weeks at once\n const resp = await fetch(\n `https://www.googleapis.com/calendar/v3/calendars/${calendarId}/events?timeMin=${now.toISOString()}&timeMax=${week2End.toISOString()}&maxResults=50&singleEvents=true&orderBy=startTime`,\n { headers: { Authorization: `Bearer ${token}` } },\n );\n const data = await resp.json();\n\n const thisWeek = (data.items ?? []).filter((e: any) => new Date(e.start?.dateTime || e.start?.date) < week1End);\n const nextWeek = (data.items ?? []).filter((e: any) => new Date(e.start?.dateTime || e.start?.date) >= week1End);\n\n const formatEvents = (events: any[]) => {\n const byDay: Record = {};\n for (const event of events) {\n const start = event.start?.dateTime || event.start?.date;\n const day = new Date(start).toLocaleDateString(\"en-US\", { weekday: \"long\", month: \"short\", day: \"numeric\", timeZone: \"America/New_York\" });\n if (!byDay[day]) byDay[day] = [];\n byDay[day].push(event);\n }\n let out = \"\";\n for (const [day, evts] of Object.entries(byDay)) {\n out += `*${day}*\\n`;\n for (const event of evts) {\n const start = event.start?.dateTime || event.start?.date;\n const isAllDay = !event.start?.dateTime;\n const timeStr = isAllDay ? \"All day\" : new Date(start).toLocaleTimeString(\"en-US\", { hour: \"numeric\", minute: \"2-digit\", timeZone: \"America/New_York\" });\n out += ` • ${event.summary}${isAllDay ? \"\" : ` @ ${timeStr}`}\\n`;\n }\n out += \"\\n\";\n }\n return out;\n };\n\n const dateLabel = now.toLocaleDateString(\"en-US\", { month: \"long\", day: \"numeric\", timeZone: \"America/New_York\" });\n let message = `📅 *Weekly Preview — ${dateLabel}*\\n\\n`;\n\n if (!thisWeek.length) {\n message += \"Nothing on the calendar this week! 🎉\\n\\n\";\n } else {\n message += formatEvents(thisWeek);\n }\n\n if (nextWeek.length) {\n message += `*Coming up the week after:*\\n`;\n for (const event of nextWeek) {\n const start = event.start?.dateTime || event.start?.date;\n const dateStr = new Date(start).toLocaleDateString(\"en-US\", { weekday: \"short\", month: \"short\", day: \"numeric\", timeZone: \"America/New_York\" });\n message += ` • ${event.summary} (${dateStr})\\n`;\n }\n message += \"\\n\";\n }\n\n message += \"_Have a great week! 🌟_\";\n\n await fetch(`https://api.telegram.org/bot${TELEGRAM_TOKEN}/sendMessage`, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ chat_id: GROUP_CHAT_ID, text: message, parse_mode: \"Markdown\" }),\n });\n\n console.log(\"Weekly review sent\");\n}","createdAt",["D",1788740989082],"branchVersion","branchId","05facaa4-90f3-48b5-bf13-4bf8572bc454","id","ea90a44b-e5c3-4abb-8fb5-1fdf1a363f60","mibbs-bot",["D",1788733325122],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","mibbs bot code","imageUrl","e8e1fec0-46e7-11f0-a801-9b9c2b15cc6a","pinnedFileId","63f1ffa8-aa41-11f1-aa27-1607ee4eb77e","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","7a1a376d-d8d2-47ee-b61d-1016a5b7e33d","tursoName","ea90a44be5c34abb8fb51fdf1a363f60","tursoHostname","ea90a44be5c34abb8fb51fdf1a363f60-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789522252250],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_100":99,"_107":103},"org",{"_100":99,"_101":-5,"_102":103,"_18":55,"_104":105,"_106":25},"branch",{"_13":89,"_32":90,"_43":42,"_91":44,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":-5,"_97":45,"_98":99},"isOwned",130,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","jeffvincent","handle","displayName","avatar","https://img.clerk.com/eyJ0eXBlIjoicHJveHkiLCJzcmMiOiJodHRwczovL2ltYWdlcy5jbGVyay5kZXYvb2F1dGhfZ2l0aHViL2ltZ18yeU41V0tQaE1XdnpOME5pR05pMVFRNkh0bUIifQ","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_43":44,"_32":45,"_38":167,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":57,"_58":59,"_60":-5,"_61":-5,"_62":63,"_64":65,"_66":67,"_68":69,"_70":168,"_72":-5,"_73":74,"_75":74,"_76":77,"_78":77,"_79":77,"_80":74,"_81":74,"_82":169,"_84":170,"_86":171,"_88":25},"tree",[158,159],"files",[158,159],"counts",{"_147":63,"_148":149,"_150":63,"_151":152,"_153":154},"contents",[130,131],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_43":143,"_32":28,"_30":31,"_134":-5,"_41":42,"_40":14,"_136":25,"_38":144,"_13":145,"_33":34,"_35":37,"_24":25,"_141":-5,"_27":146},{"_43":132,"_32":133,"_30":57,"_134":-5,"_41":42,"_40":135,"_136":25,"_38":137,"_13":138,"_33":139,"_35":140,"_24":25,"_141":-5,"_27":142},"e6421e3b-4ebb-4b1f-a0db-f15304e6c4bf","main.ts","parentId",15,"latest",["D",1788740764797],14,"http","// Family Manager Telegram Bot — HTTP Val\n// Deploy this as an HTTP val on Val.town. Set the webhook URL in Telegram after deploying.\n\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { blob } from \"https://esm.town/v/std/blob\";\nimport Anthropic from \"npm:@anthropic-ai/sdk\";\n\n// ── Database ──────────────────────────────────────────────────────────────────\n\nasync function initDb() {\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS fm_tasks (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n text TEXT NOT NULL,\n created_by TEXT,\n created_at TEXT NOT NULL,\n due_date TEXT,\n completed INTEGER NOT NULL DEFAULT 0,\n completed_at TEXT\n )`);\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS fm_info (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n key TEXT NOT NULL,\n value TEXT NOT NULL,\n created_by TEXT,\n created_at TEXT NOT NULL\n )`);\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS fm_messages (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n chat_id INTEGER NOT NULL,\n role TEXT NOT NULL,\n content TEXT NOT NULL,\n user_name TEXT,\n created_at TEXT NOT NULL\n )`);\n}\n\nfunction rowsToObjects(result: { rows: any[][]; columns: string[] }): Record[] {\n return result.rows.map((row) => {\n const obj: Record = {};\n result.columns.forEach((col, i) => { obj[col] = row[i]; });\n return obj;\n });\n}\n\nasync function addTask(text: string, createdBy: string, dueDate?: string): Promise {\n const result = await sqlite.execute({\n sql: \"INSERT INTO fm_tasks (text, created_by, created_at, due_date) VALUES (?, ?, ?, ?)\",\n args: [text, createdBy, new Date().toISOString(), dueDate ?? null],\n });\n return result.rowsAffected as unknown as number;\n}\n\nasync function listTasks(): Promise<{ id: number; text: string; created_by: string; due_date: string | null }[]> {\n const result = await sqlite.execute(\"SELECT id, text, created_by, due_date FROM fm_tasks WHERE completed = 0 ORDER BY created_at DESC\");\n return rowsToObjects(result) as any;\n}\n\nasync function completeTask(id: number): Promise {\n const result = await sqlite.execute({\n sql: \"UPDATE fm_tasks SET completed = 1, completed_at = ? WHERE id = ? AND completed = 0\",\n args: [new Date().toISOString(), id],\n });\n return (result.rowsAffected ?? 0) > 0;\n}\n\nasync function storeInfo(key: string, value: string, createdBy: string): Promise {\n await sqlite.execute({\n sql: \"INSERT INTO fm_info (key, value, created_by, created_at) VALUES (?, ?, ?, ?)\",\n args: [key, value, createdBy, new Date().toISOString()],\n });\n}\n\nasync function saveMessage(chatId: number, role: \"user\" | \"assistant\", content: string, userName?: string): Promise {\n console.log(`saveMessage: ${role}, chat ${chatId}`);\n try {\n await sqlite.execute({\n sql: \"INSERT INTO fm_messages (chat_id, role, content, user_name, created_at) VALUES (?, ?, ?, ?, ?)\",\n args: [chatId, role, content, userName ?? null, new Date().toISOString()],\n });\n console.log(\"saveMessage: INSERT succeeded\");\n } catch (err) {\n console.error(\"saveMessage: INSERT failed:\", err);\n }\n}\n\nasync function getRecentMessages(chatId: number, limit = 20): Promise<{ role: string; content: string }[]> {\n const result = await sqlite.execute({\n sql: \"SELECT role, content FROM fm_messages WHERE chat_id = ? ORDER BY id DESC LIMIT ?\",\n args: [chatId, limit],\n });\n return rowsToObjects(result).reverse() as any;\n}\n\nasync function getInfo(query?: string): Promise<{ key: string; value: string }[]> {\n let result;\n if (query) {\n result = await sqlite.execute({\n sql: \"SELECT key, value FROM fm_info WHERE key LIKE ? OR value LIKE ? ORDER BY created_at DESC\",\n args: [`%${query}%`, `%${query}%`],\n });\n } else {\n result = await sqlite.execute(\"SELECT key, value FROM fm_info ORDER BY created_at DESC\");\n }\n return rowsToObjects(result) as any;\n}\n\n// ── Telegram ──────────────────────────────────────────────────────────────────\n\nconst TELEGRAM_TOKEN = Deno.env.get(\"TELEGRAM_TOKEN\")!;\nconst TG_API = `https://api.telegram.org/bot${TELEGRAM_TOKEN}`;\n\nasync function sendMessage(chatId: number, text: string, parseMode = \"Markdown\") {\n await fetch(`${TG_API}/sendMessage`, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ chat_id: chatId, text, parse_mode: parseMode }),\n });\n}\n\nasync function sendChatAction(chatId: number, action = \"typing\") {\n await fetch(`${TG_API}/sendChatAction`, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ chat_id: chatId, action }),\n });\n}\n\nasync function getBotUsername(): Promise {\n const envUsername = Deno.env.get(\"BOT_USERNAME\");\n if (envUsername) return envUsername;\n const resp = await fetch(`${TG_API}/getMe`);\n const data = await resp.json();\n return data.result?.username ?? \"\";\n}\n\n// ── Google Calendar ───────────────────────────────────────────────────────────\n\nasync function getGoogleAccessToken(): Promise {\n let tokenData: any = await blob.getJSON(\"gcalToken\").catch(() => null);\n console.log(\"gcalToken from blob:\", tokenData ? \"found\" : \"not found\");\n\n if (!tokenData) {\n const tokenJson = Deno.env.get(\"GOOGLE_TOKEN_JSON\");\n console.log(\"GOOGLE_TOKEN_JSON env:\", tokenJson ? `set (${tokenJson.length} chars)` : \"NOT SET\");\n if (!tokenJson) return null;\n try {\n const raw = JSON.parse(atob(tokenJson));\n console.log(\"token keys:\", Object.keys(raw));\n // Handle multi-account format from shared google-auth.js\n if (raw.accounts) {\n const accountId = raw.defaultAccount || Object.keys(raw.accounts)[0];\n tokenData = raw.accounts[accountId];\n console.log(\"resolved account:\", accountId, \"| token keys:\", Object.keys(tokenData));\n } else {\n tokenData = raw;\n }\n } catch (err) {\n console.error(\"Failed to parse GOOGLE_TOKEN_JSON:\", err);\n return null;\n }\n }\n\n // Handle both Python format (token/expiry) and JS format (access_token/expiry_date)\n const accessToken: string | null = tokenData.access_token ?? tokenData.token ?? null;\n const refreshToken: string | null = tokenData.refresh_token ?? null;\n const expiryMs: number = tokenData.expiry_date\n ? (typeof tokenData.expiry_date === \"number\" ? tokenData.expiry_date : new Date(tokenData.expiry_date).getTime())\n : tokenData.expiry\n ? new Date(tokenData.expiry).getTime()\n : 0;\n\n if (expiryMs - Date.now() < 5 * 60 * 1000) {\n const credsJson = Deno.env.get(\"GOOGLE_CREDENTIALS_JSON\");\n if (!credsJson || !refreshToken) return accessToken;\n try {\n const creds = JSON.parse(atob(credsJson));\n const client = creds.installed || creds.web;\n const resp = 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: client.client_id,\n client_secret: client.client_secret,\n refresh_token: refreshToken,\n grant_type: \"refresh_token\",\n }),\n });\n const newToken = await resp.json();\n if (newToken.error) {\n console.error(\"Token refresh error:\", newToken.error, newToken.error_description);\n return accessToken;\n }\n const refreshed = { ...tokenData, access_token: newToken.access_token, token: newToken.access_token, expiry_date: Date.now() + (newToken.expires_in || 3600) * 1000 };\n await blob.setJSON(\"gcalToken\", refreshed);\n return newToken.access_token;\n } catch (err) {\n console.error(\"Token refresh failed:\", err);\n return accessToken;\n }\n }\n\n return accessToken;\n}\n\nasync function listCalendars(): Promise {\n const token = await getGoogleAccessToken();\n if (!token) return \"Calendar not configured.\";\n const resp = await fetch(\"https://www.googleapis.com/calendar/v3/users/me/calendarList\", {\n headers: { Authorization: `Bearer ${token}` },\n });\n const data = await resp.json();\n if (!data.items?.length) return \"No calendars found.\";\n return data.items.map((c: any) => `• ${c.summary}\\n ID: \\`${c.id}\\``).join(\"\\n\");\n}\n\nasync function getCalendarEvents(daysAhead = 7): Promise {\n const token = await getGoogleAccessToken();\n if (!token) return \"Calendar not configured.\";\n const calendarId = encodeURIComponent(Deno.env.get(\"CALENDAR_ID\") || \"primary\");\n const now = new Date().toISOString();\n const end = new Date(Date.now() + daysAhead * 86400000).toISOString();\n const resp = await fetch(\n `https://www.googleapis.com/calendar/v3/calendars/${calendarId}/events?timeMin=${now}&timeMax=${end}&maxResults=20&singleEvents=true&orderBy=startTime`,\n { headers: { Authorization: `Bearer ${token}` } },\n );\n const data = await resp.json();\n if (!data.items?.length) return \"No upcoming events.\";\n return data.items.map((e: any) => `• ${e.summary} — ${e.start?.dateTime || e.start?.date}`).join(\"\\n\");\n}\n\nasync function createCalendarEvent(summary: string, startDt: string, endDt: string, description = \"\"): Promise {\n const token = await getGoogleAccessToken();\n if (!token) return \"Calendar not configured.\";\n const calendarId = encodeURIComponent(Deno.env.get(\"CALENDAR_ID\") || \"primary\");\n const timezone = Deno.env.get(\"TIMEZONE\") || \"America/New_York\";\n const resp = await fetch(\n `https://www.googleapis.com/calendar/v3/calendars/${calendarId}/events`,\n {\n method: \"POST\",\n headers: { Authorization: `Bearer ${token}`, \"Content-Type\": \"application/json\" },\n body: JSON.stringify({\n summary,\n description,\n start: { dateTime: startDt, timeZone: timezone },\n end: { dateTime: endDt, timeZone: timezone },\n }),\n },\n );\n const data = await resp.json();\n return data.id ? `Event \"${summary}\" added to calendar.` : \"Failed to add event.\";\n}\n\n// ── Claude Agent ──────────────────────────────────────────────────────────────\n\nconst anthropic = new Anthropic({ apiKey: Deno.env.get(\"ANTHROPIC_API_KEY\")! });\n\nconst TOOLS: Anthropic.Tool[] = [\n {\n name: \"add_task\",\n description: \"Add a new task to the household task list. Tasks can be assigned to a person, e.g. 'Jeff should mow the lawn' or 'Pick up groceries'.\",\n input_schema: {\n type: \"object\",\n properties: {\n text: { type: \"string\", description: \"Task description, including who should do it if specified\" },\n due_date: { type: \"string\", description: \"Optional due date in ISO 8601 format\" },\n },\n required: [\"text\"],\n },\n },\n {\n name: \"list_tasks\",\n description: \"Get all incomplete household tasks\",\n input_schema: { type: \"object\", properties: {}, required: [] },\n },\n {\n name: \"complete_task\",\n description: \"Mark a task as completed by its ID\",\n input_schema: {\n type: \"object\",\n properties: { task_id: { type: \"number\", description: \"Task ID to complete\" } },\n required: [\"task_id\"],\n },\n },\n {\n name: \"get_calendar_events\",\n description: \"Get upcoming calendar events\",\n input_schema: {\n type: \"object\",\n properties: { days_ahead: { type: \"number\", description: \"How many days ahead to look (default 7)\" } },\n required: [],\n },\n },\n {\n name: \"add_calendar_event\",\n description: \"Add an event to the family calendar\",\n input_schema: {\n type: \"object\",\n properties: {\n summary: { type: \"string\", description: \"Event title\" },\n start_dt: { type: \"string\", description: \"Start datetime ISO 8601\" },\n end_dt: { type: \"string\", description: \"End datetime ISO 8601\" },\n description: { type: \"string\", description: \"Optional description\" },\n },\n required: [\"summary\", \"start_dt\", \"end_dt\"],\n },\n },\n {\n name: \"store_info\",\n description: \"Store important household info (doctor names, account details, important dates, etc.)\",\n input_schema: {\n type: \"object\",\n properties: {\n key: { type: \"string\", description: \"Label for the info\" },\n value: { type: \"string\", description: \"The info to store\" },\n },\n required: [\"key\", \"value\"],\n },\n },\n {\n name: \"retrieve_info\",\n description: \"Search stored household information\",\n input_schema: {\n type: \"object\",\n properties: { query: { type: \"string\", description: \"Search term\" } },\n required: [],\n },\n },\n];\n\nasync function executeTool(name: string, input: any, chatId: number, userName: string): Promise {\n try {\n switch (name) {\n case \"add_task\": {\n await addTask(input.text, userName, input.due_date);\n return `Task added: ${input.text}`;\n }\n case \"list_tasks\": {\n const tasks = await listTasks();\n if (!tasks.length) return \"No pending tasks.\";\n return tasks.map((t) => `[${t.id}] ${t.text}${t.due_date ? ` (due: ${t.due_date})` : \"\"}`).join(\"\\n\");\n }\n case \"complete_task\": {\n const ok = await completeTask(input.task_id);\n return ok ? \"Task marked complete ✅\" : `No incomplete task with ID ${input.task_id}.`;\n }\n case \"get_calendar_events\":\n return await getCalendarEvents(input.days_ahead || 7);\n case \"add_calendar_event\":\n return await createCalendarEvent(input.summary, input.start_dt, input.end_dt, input.description || \"\");\n case \"store_info\":\n await storeInfo(input.key, input.value, userName);\n return `Saved: ${input.key} = ${input.value}`;\n case \"retrieve_info\": {\n const items = await getInfo(input.query);\n if (!items.length) return \"Nothing found.\";\n return items.map((i) => `• ${i.key}: ${i.value}`).join(\"\\n\");\n }\n default:\n return `Unknown tool: ${name}`;\n }\n } catch (err) {\n return `Error in ${name}: ${String(err)}`;\n }\n}\n\nasync function processMessage(text: string, chatId: number, userName: string): Promise {\n const familyName = Deno.env.get(\"FAMILY_NAME\") || \"the family\";\n const systemPrompt = `You are a warm, helpful family assistant bot for ${familyName}. You live in their Telegram group chat.\n\nCapabilities: shared household task list (tasks can be assigned to a person, e.g. \"Jeff should mow the lawn\"), Google Calendar, and storing household info.\n\nBe concise and warm. Current UTC time: ${new Date().toISOString()}.\n\nFor reminders, convert times to ISO 8601 UTC. For relative times (\"in 2 hours\"), calculate from now.`;\n\n // Load conversation history for context\n const history = await getRecentMessages(chatId, 20);\n await saveMessage(chatId, \"user\", `${userName}: ${text}`, userName);\n\n const messages: Anthropic.MessageParam[] = [\n ...history.map((m) => ({ role: m.role as \"user\" | \"assistant\", content: m.content })),\n { role: \"user\", content: `${userName}: ${text}` },\n ];\n\n for (let i = 0; i < 10; i++) {\n const response = await anthropic.messages.create({\n model: \"claude-sonnet-4-6\",\n max_tokens: 1024,\n system: systemPrompt,\n tools: TOOLS,\n messages,\n });\n\n if (response.stop_reason === \"end_turn\") {\n for (const block of response.content) {\n if (block.type === \"text\") {\n await saveMessage(chatId, \"assistant\", block.text);\n return block.text;\n }\n }\n return \"Done.\";\n }\n\n if (response.stop_reason === \"tool_use\") {\n messages.push({ role: \"assistant\", content: response.content });\n const results: Anthropic.ToolResultBlockParam[] = [];\n for (const block of response.content) {\n if (block.type === \"tool_use\") {\n const result = await executeTool(block.name, block.input as any, chatId, userName);\n results.push({ type: \"tool_result\", tool_use_id: block.id, content: result });\n }\n }\n messages.push({ role: \"user\", content: results });\n } else {\n break;\n }\n }\n return \"Sorry, I couldn't complete that.\";\n}\n\n// ── Main Handler ──────────────────────────────────────────────────────────────\n\nexport default async function (req: Request): Promise {\n if (req.method !== \"POST\") return new Response(\"Family Bot OK\");\n\n try {\n await initDb();\n } catch (err) {\n console.error(\"initDb failed:\", err);\n }\n\n let update: any;\n try {\n update = await req.json();\n } catch {\n return new Response(\"Bad Request\", { status: 400 });\n }\n\n const message = update.message || update.edited_message;\n if (!message?.text) return new Response(\"OK\");\n\n const chatId: number = message.chat.id;\n const chatType: string = message.chat.type;\n const text: string = message.text;\n const userName: string = message.from?.first_name || \"Someone\";\n const respondToAll = Deno.env.get(\"RESPOND_TO_ALL\") === \"true\";\n console.log(`message: \"${text}\" | type: ${chatType} | respondToAll: ${respondToAll}`);\n\n if (text.startsWith(\"/start\")) {\n await sendMessage(\n chatId,\n \"👋 Hi! I'm your family manager bot.\\n\\nTalk to me naturally:\\n• \\\"Add a task to call the plumber\\\"\\n• \\\"Remind me to take out the trash at 8pm\\\"\\n• \\\"What's on the calendar this week?\\\"\\n• \\\"Remember the WiFi password is xyz123\\\"\\n\\nCommands: /tasks · /done · /info · /help\",\n );\n return new Response(\"OK\");\n }\n\n if (text.startsWith(\"/calendars\")) {\n const list = await listCalendars();\n await sendMessage(chatId, `*Your calendars:*\\n${list}`);\n return new Response(\"OK\");\n }\n\n if (text.startsWith(\"/tasks\")) {\n await initDb();\n const tasks = await listTasks();\n if (!tasks.length) {\n await sendMessage(chatId, \"No pending tasks! 🎉\");\n } else {\n const lines = tasks.map((t) => `[${t.id}] ${t.text}${t.due_date ? ` _(due ${t.due_date})_` : \"\"}`);\n await sendMessage(chatId, `*Pending tasks:*\\n${lines.join(\"\\n\")}`);\n }\n return new Response(\"OK\");\n }\n\n if (text.startsWith(\"/done\")) {\n const parts = text.trim().split(/\\s+/);\n const id = parseInt(parts[1]);\n if (isNaN(id)) {\n await sendMessage(chatId, \"Usage: /done \");\n } else {\n const ok = await completeTask(id);\n await sendMessage(chatId, ok ? `✅ Task ${id} marked complete.` : `No incomplete task with ID ${id}.`);\n }\n return new Response(\"OK\");\n }\n\n if (text.startsWith(\"/info\")) {\n const query = text.replace(\"/info\", \"\").trim() || undefined;\n const items = await getInfo(query);\n if (!items.length) {\n await sendMessage(chatId, query ? `No info found for \"${query}\".` : \"No stored information yet.\");\n } else {\n await sendMessage(chatId, items.map((i) => `*${i.key}:* ${i.value}`).join(\"\\n\"));\n }\n return new Response(\"OK\");\n }\n\n if (text.startsWith(\"/help\")) {\n await sendMessage(\n chatId,\n \"*Family Manager Bot*\\n\\nJust talk to me! Examples:\\n• \\\"Add a task to buy groceries\\\"\\n• \\\"Remind me at 5pm to pick up the kids\\\"\\n• \\\"What's on the calendar this week?\\\"\\n• \\\"Remember that Dr. Smith's number is 555-1234\\\"\\n\\n*Commands:*\\n/tasks — Pending tasks\\n/done — Complete a task\\n/info [search] — Stored information\\n/help — This message\",\n );\n return new Response(\"OK\");\n }\n\n // In groups: only respond to @mentions unless RESPOND_TO_ALL\n if (chatType !== \"private\" && !respondToAll) {\n const botUsername = await getBotUsername();\n if (!text.includes(`@${botUsername}`)) return new Response(\"OK\");\n }\n\n // Strip @mention from message text\n let messageText = text;\n const botUsername = await getBotUsername();\n messageText = messageText.replace(`@${botUsername}`, \"\").trim();\n\n await sendChatAction(chatId, \"typing\");\n\n try {\n const response = await processMessage(messageText, chatId, userName);\n await sendMessage(chatId, response);\n } catch (err) {\n console.error(\"processMessage error:\", err);\n await sendMessage(chatId, \"Something went wrong — please try again.\");\n }\n\n return new Response(\"OK\");\n}","label",[133],"1f41f6a7-f2c0-4408-be72-312641272f1d",["D",1788740989082],5,[28],"pulls","branches",1,"forks","envVars",{"_155":135,"_157":63},"connections",{"_155":63,"_156":63},"count","unfilledCount","emptyCount",{"_43":143,"_32":28,"_30":31,"_134":-5,"_41":42,"_40":14,"_136":25,"_38":164,"_13":145,"_33":34,"_35":37,"_24":25,"_141":-5,"_161":165,"_27":166},{"_43":132,"_32":133,"_30":57,"_134":-5,"_41":42,"_40":135,"_136":25,"_38":160,"_13":138,"_33":139,"_35":140,"_24":25,"_141":-5,"_161":162,"_27":163},["D",1788740764797],"children",[],[133],["D",1788740989082],[],[28],["D",1788733325122],["D",1789522252250],{"_100":99,"_107":103},{"_100":99,"_101":-5,"_102":103,"_18":55,"_104":105,"_106":25},{"_13":89,"_32":90,"_43":42,"_91":44,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":-5,"_97":45,"_98":99},"ctx",{"_82":-5,"_127":205,"_206":207,"_208":209,"_210":25,"_211":25,"_212":25,"_213":59,"_214":-5,"_215":-7,"_216":-7,"_217":63,"_218":25,"_219":25,"_220":-5,"_221":25,"_222":25,"_223":25,"_224":-5},"ENV",{"_176":177,"_178":179,"_180":90,"_181":182,"_183":184,"_185":186,"_187":188,"_189":190,"_191":192,"_193":194,"_195":196,"_197":198,"_199":200,"_201":202,"_203":204},"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 · v21