[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_155":156,"_157":158},"routes/_app.x.$handle.$name",{"_95":94,"_32":45,"_104":85,"_27":105,"_13":14,"_106":-5,"_11":107,"_108":109,"_110":111,"_112":113,"_114":115,"_20":-5,"_116":-5,"_117":-5,"_118":25,"_119":120,"_121":122,"_123":-5,"_124":-5,"_125":126},"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":-5,"_57":25,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":-5,"_65":-5,"_66":-5,"_67":-5,"_68":69,"_70":69,"_71":72,"_73":72,"_74":72,"_75":69,"_76":69,"_77":78,"_79":80,"_81":82,"_83":25},"version",8,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":34,"_35":37,"_38":39,"_40":14,"_41":42,"_24":25},"previous",{"_30":31,"_32":28,"_33":34,"_35":36},"deleted",false,"deletedHere","path","main.ts","latestPath","fileId","92b08b3c-54ad-11f1-af2b-ee650bb23af1","name","fileType","http","content","// fun-cal SMS endpoint.\n//\n// Twilio webhook (application/x-www-form-urlencoded) → calendar event in the \"Maybe\" calendar.\n//\n// Flow:\n// 1. Verify Twilio signature (HMAC-SHA1).\n// 2. Allowlist the From number.\n// 3. If a pending-clarification exists for this number: treat the new SMS as a date update,\n// patch the existing calendar event, clear pending state, reply.\n// 4. Otherwise: extract event from message body (+ optional URL fetch), create calendar event.\n// - high/medium confidence → reply with link, done.\n// - low confidence → reply asking for the correct date, store pending state.\n//\n// Env vars (set as Val.town secrets):\n// ANTHROPIC_API_KEY\n// GOOGLE_CLIENT_ID\n// GOOGLE_CLIENT_SECRET\n// GOOGLE_REFRESH_TOKEN\n// GOOGLE_CALENDAR_ID\n// TIMEZONE IANA tz, e.g. America/New_York\n// TWILIO_AUTH_TOKEN for signature verification\n// ALLOWED_NUMBERS comma-separated E.164 list, e.g. \"+15551234567,+15557654321\"\n\nimport { blob } from \"https://esm.town/v/std/blob\";\n\nconst env = (k: string): string => {\n const v = (globalThis as any).Deno?.env?.get?.(k) ??\n (globalThis as any).process?.env?.[k];\n if (!v) throw new Error(`Missing env var: ${k}`);\n return v;\n};\n\nconst PENDING_TTL_MS = 60 * 60 * 1000; // 1 hour\n\ntype EventType =\n | \"comedy\"\n | \"movie\"\n | \"performance\"\n | \"party\"\n | \"class\"\n | \"dinner\"\n | \"outdoor\"\n | \"other\";\n\ntype ExtractedEvent = {\n title: string;\n start_date: string;\n start_time: string | null;\n end_time: string | null;\n location: string;\n notes: string;\n confidence: \"high\" | \"medium\" | \"low\";\n event_type: EventType;\n tickets_required: boolean;\n price: string;\n ticket_url: string;\n};\n\nconst EVENT_COLOR: Record = {\n comedy: \"6\", // tangerine\n movie: \"8\", // graphite\n performance: \"9\", // blueberry\n party: \"11\", // tomato\n class: \"2\", // sage\n dinner: \"7\", // peacock\n outdoor: \"10\", // basil\n other: undefined, // default calendar color\n};\n\ntype PendingState = {\n eventId: string;\n title: string;\n createdAt: number;\n};\n\nasync function verifyTwilioSignature(\n url: string,\n body: string,\n signature: string,\n): Promise {\n const params = new URLSearchParams(body);\n const sortedKeys = [...new Set(params.keys())].sort();\n let data = url;\n for (const k of sortedKeys) data += k + params.get(k);\n\n const enc = new TextEncoder();\n const key = await crypto.subtle.importKey(\n \"raw\",\n enc.encode(env(\"TWILIO_AUTH_TOKEN\")),\n { name: \"HMAC\", hash: \"SHA-1\" },\n false,\n [\"sign\"],\n );\n const sig = await crypto.subtle.sign(\"HMAC\", key, enc.encode(data));\n const computed = btoa(String.fromCharCode(...new Uint8Array(sig)));\n return computed === signature;\n}\n\nfunction twiml(message: string): Response {\n const escaped = message.replace(/&/g, \"&\").replace(//g,\n \">\",\n );\n return new Response(\n `${escaped}`,\n { headers: { \"content-type\": \"text/xml; charset=utf-8\" } },\n );\n}\n\nfunction extractUrls(text: string): string[] {\n const re = /https?:\\/\\/[^\\s]+/g;\n return text.match(re) ?? [];\n}\n\nasync function fetchUrlText(url: string): Promise {\n try {\n const r = await fetch(url, {\n signal: AbortSignal.timeout(8000),\n headers: { \"user-agent\": \"Mozilla/5.0 (compatible; fun-cal/1.0)\" },\n redirect: \"follow\",\n });\n if (!r.ok) return \"\";\n const ct = r.headers.get(\"content-type\") ?? \"\";\n if (!ct.includes(\"text/html\") && !ct.includes(\"text/plain\")) return \"\";\n const html = await r.text();\n\n const structured: string[] = [];\n\n const titleMatch = html.match(/]*>([^<]+)<\\/title>/i);\n if (titleMatch) structured.push(`Page title: ${titleMatch[1].trim()}`);\n\n const metaTags: string[] = [];\n const metaRe = /]+>/gi;\n let mm: RegExpExecArray | null;\n while ((mm = metaRe.exec(html)) !== null) {\n const tag = mm[0];\n const nameMatch = tag.match(/(?:name|property)=[\"']([^\"']+)[\"']/i);\n const contentMatch = tag.match(/content=[\"']([^\"']*)[\"']/i);\n if (\n nameMatch && contentMatch &&\n /^(og:|twitter:|description$)/i.test(nameMatch[1])\n ) {\n metaTags.push(`${nameMatch[1]}: ${contentMatch[1]}`);\n }\n }\n if (metaTags.length) structured.push(\"Meta tags:\\n\" + metaTags.join(\"\\n\"));\n\n const jsonLdRe =\n /]*type=[\"']application\\/ld\\+json[\"'][^>]*>([\\s\\S]*?)<\\/script>/gi;\n let jm: RegExpExecArray | null;\n const ldBlocks: string[] = [];\n while ((jm = jsonLdRe.exec(html)) !== null) ldBlocks.push(jm[1].trim());\n if (ldBlocks.length) {\n structured.push(\"JSON-LD:\\n\" + ldBlocks.join(\"\\n---\\n\"));\n }\n\n const stripped = html\n .replace(//gi, \" \")\n .replace(//gi, \" \")\n .replace(/<[^>]+>/g, \" \")\n .replace(/ /g, \" \")\n .replace(/\\s+/g, \" \")\n .trim();\n\n const structuredPart = structured.length\n ? structured.join(\"\\n\\n\") + \"\\n\\n\"\n : \"\";\n const budget = 12000 - structuredPart.length;\n return (structuredPart + \"Page text:\\n\" + stripped).slice(\n 0,\n structuredPart.length + Math.max(0, budget),\n );\n } catch {\n return \"\";\n }\n}\n\nasync function callClaude(\n systemAndUser: { system?: string; user: string },\n tool: any,\n): Promise {\n const resp = await fetch(\"https://api.anthropic.com/v1/messages\", {\n method: \"POST\",\n headers: {\n \"x-api-key\": env(\"ANTHROPIC_API_KEY\"),\n \"anthropic-version\": \"2023-06-01\",\n \"content-type\": \"application/json\",\n },\n body: JSON.stringify({\n model: \"claude-sonnet-4-6\",\n max_tokens: 1024,\n ...(systemAndUser.system ? { system: systemAndUser.system } : {}),\n tools: [tool],\n tool_choice: { type: \"tool\", name: tool.name },\n messages: [{ role: \"user\", content: systemAndUser.user }],\n }),\n });\n if (!resp.ok) {\n throw new Error(`Anthropic ${resp.status}: ${await resp.text()}`);\n }\n const data = await resp.json() as {\n content: { type: string; input?: any }[];\n };\n const t = data.content.find((c) => c.type === \"tool_use\");\n if (!t?.input) {\n throw new Error(`No tool_use in response: ${JSON.stringify(data)}`);\n }\n return t.input;\n}\n\nasync function extractEvent(text: string, tz: string): Promise {\n const today = new Date().toLocaleDateString(\"en-CA\", { timeZone: tz });\n const urls = extractUrls(text);\n let augmented = text;\n if (urls.length) {\n const fetched = await fetchUrlText(urls[0]);\n if (fetched) augmented += `\\n\\n--- contents of ${urls[0]} ---\\n${fetched}`;\n }\n return await callClaude({\n user:\n `Extract event details from the source below. Today's date is ${today} (${tz}). If no date is clearly stated, set start_date to today and confidence to \"low\" — a human will fix it. Prefer dates in the future when ambiguous. The source may include structured data (JSON-LD, OpenGraph meta tags) — when present, these contain the most authoritative info; prefer them over text inferred from stripped HTML.\\n\\nFor event_type, classify into the closest of: comedy, movie, performance, party, class, dinner, outdoor, other. Use \"performance\" for concerts, plays, shows, dance, theater, sports games. Use \"party\" for social gatherings, hangouts, bar nights, drinks, celebrations. Use \"class\" for workshops, lectures, courses, educational events, anything you'd \"learn\" at. Use \"dinner\" for restaurant outings, food-focused events, dinner parties, food tours. Use \"outdoor\" for hikes, runs, picnics, beach days, sports played (not watched), camping. Use \"other\" only when nothing else fits.\\n\\nFor price, extract a short human-readable string like \"Free\", \"$25\", \"$50-100\", or \"\" if not stated.\\n\\nFor ticket_url, only fill in when there's a distinct buy/RSVP link different from the source URL; otherwise \"\".\\n\\nSource:\\n${augmented}`,\n }, {\n name: \"create_event\",\n description: \"Extract a calendar event from the provided text.\",\n input_schema: {\n type: \"object\",\n properties: {\n title: { type: \"string\" },\n start_date: { type: \"string\", description: \"ISO date YYYY-MM-DD\" },\n start_time: {\n type: [\"string\", \"null\"],\n description: \"24h HH:MM, or null for all-day\",\n },\n end_time: { type: [\"string\", \"null\"] },\n location: { type: \"string\" },\n notes: { type: \"string\", description: \"One-to-two sentence summary.\" },\n confidence: { type: \"string\", enum: [\"high\", \"medium\", \"low\"] },\n event_type: {\n type: \"string\",\n enum: [\n \"comedy\",\n \"movie\",\n \"performance\",\n \"party\",\n \"class\",\n \"dinner\",\n \"outdoor\",\n \"other\",\n ],\n },\n tickets_required: {\n type: \"boolean\",\n description:\n \"True if attendance requires a ticket/RSVP/registration.\",\n },\n price: {\n type: \"string\",\n description:\n \"Short price string like 'Free', '$25', '$50-100', or '' if unknown.\",\n },\n ticket_url: {\n type: \"string\",\n description:\n \"Direct buy/RSVP URL distinct from the source URL, or '' if none.\",\n },\n },\n required: [\n \"title\",\n \"start_date\",\n \"start_time\",\n \"end_time\",\n \"location\",\n \"notes\",\n \"confidence\",\n \"event_type\",\n \"tickets_required\",\n \"price\",\n \"ticket_url\",\n ],\n },\n });\n}\n\nasync function extractDateUpdate(\n text: string,\n tz: string,\n originalTitle: string,\n): Promise<\n { start_date: string; start_time: string | null; end_time: string | null }\n> {\n const today = new Date().toLocaleDateString(\"en-CA\", { timeZone: tz });\n return await callClaude({\n user:\n `The user is clarifying the date/time for an existing event titled \"${originalTitle}\". Today is ${today} (${tz}). Extract a concrete date/time from their reply.\\n\\nReply:\\n${text}`,\n }, {\n name: \"update_date\",\n description: \"Extract a date/time clarification.\",\n input_schema: {\n type: \"object\",\n properties: {\n start_date: { type: \"string\", description: \"ISO date YYYY-MM-DD\" },\n start_time: {\n type: [\"string\", \"null\"],\n description: \"24h HH:MM, or null for all-day\",\n },\n end_time: { type: [\"string\", \"null\"] },\n },\n required: [\"start_date\", \"start_time\", \"end_time\"],\n },\n });\n}\n\nasync function getGoogleAccessToken(): Promise {\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: env(\"GOOGLE_CLIENT_ID\"),\n client_secret: env(\"GOOGLE_CLIENT_SECRET\"),\n refresh_token: env(\"GOOGLE_REFRESH_TOKEN\"),\n grant_type: \"refresh_token\",\n }),\n });\n if (!resp.ok) {\n throw new Error(`Google token ${resp.status}: ${await resp.text()}`);\n }\n return (await resp.json() as { access_token: string }).access_token;\n}\n\nfunction addHour(hhmm: string): string {\n const [h, m] = hhmm.split(\":\").map(Number);\n const t = (h + 1) * 60 + m;\n return `${String(Math.floor((t / 60) % 24)).padStart(2, \"0\")}:${\n String(t % 60).padStart(2, \"0\")\n }`;\n}\n\nfunction startEndPayload(\n date: string,\n start_time: string | null,\n end_time: string | null,\n tz: string,\n) {\n if (start_time) {\n return {\n start: { dateTime: `${date}T${start_time}:00`, timeZone: tz },\n end: {\n dateTime: `${date}T${end_time ?? addHour(start_time)}:00`,\n timeZone: tz,\n },\n };\n }\n return { start: { date }, end: { date } };\n}\n\nasync function createEvent(\n extracted: ExtractedEvent,\n sourceText: string,\n tz: string,\n): Promise<{ htmlLink: string; id: string }> {\n const accessToken = await getGoogleAccessToken();\n const calId = env(\"GOOGLE_CALENDAR_ID\");\n const flag = extracted.confidence === \"low\"\n ? \"⚠️ Date unclear — text to fix\\n\\n\"\n : \"\";\n const urls = extractUrls(sourceText);\n\n const metaLines: string[] = [];\n metaLines.push(`Type: ${extracted.event_type}`);\n metaLines.push(\n `Tickets required: ${extracted.tickets_required ? \"Yes\" : \"No\"}`,\n );\n if (extracted.price) metaLines.push(`Price: ${extracted.price}`);\n if (extracted.ticket_url) metaLines.push(`Tickets: ${extracted.ticket_url}`);\n if (urls.length) metaLines.push(`Source: ${urls[0]}`);\n\n const description = `${flag}${extracted.notes}\\n\\n${\n metaLines.join(\"\\n\")\n }\\n\\n— captured via fun-cal SMS\\n\\nOriginal text:\\n${sourceText}`;\n\n const colorId = EVENT_COLOR[extracted.event_type];\n\n const resp = await fetch(\n `https://www.googleapis.com/calendar/v3/calendars/${\n encodeURIComponent(calId)\n }/events`,\n {\n method: \"POST\",\n headers: {\n authorization: `Bearer ${accessToken}`,\n \"content-type\": \"application/json\",\n },\n body: JSON.stringify({\n summary: extracted.title,\n location: extracted.location || undefined,\n description,\n ...(colorId ? { colorId } : {}),\n ...startEndPayload(\n extracted.start_date,\n extracted.start_time,\n extracted.end_time,\n tz,\n ),\n }),\n },\n );\n if (!resp.ok) {\n throw new Error(`Calendar insert ${resp.status}: ${await resp.text()}`);\n }\n return await resp.json() as { htmlLink: string; id: string };\n}\n\nasync function patchEventDate(\n eventId: string,\n update: {\n start_date: string;\n start_time: string | null;\n end_time: string | null;\n },\n tz: string,\n): Promise<{ htmlLink: string }> {\n const accessToken = await getGoogleAccessToken();\n const calId = env(\"GOOGLE_CALENDAR_ID\");\n const resp = await fetch(\n `https://www.googleapis.com/calendar/v3/calendars/${\n encodeURIComponent(calId)\n }/events/${encodeURIComponent(eventId)}`,\n {\n method: \"PATCH\",\n headers: {\n authorization: `Bearer ${accessToken}`,\n \"content-type\": \"application/json\",\n },\n body: JSON.stringify(\n startEndPayload(\n update.start_date,\n update.start_time,\n update.end_time,\n tz,\n ),\n ),\n },\n );\n if (!resp.ok) {\n throw new Error(`Calendar patch ${resp.status}: ${await resp.text()}`);\n }\n return await resp.json() as { htmlLink: string };\n}\n\nfunction pendingKey(phone: string): string {\n return `funcal:pending:${phone}`;\n}\n\nasync function getPending(phone: string): Promise {\n const v = await blob.getJSON(pendingKey(phone)) as PendingState | null;\n if (!v) return null;\n if (Date.now() - v.createdAt > PENDING_TTL_MS) {\n await blob.delete(pendingKey(phone));\n return null;\n }\n return v;\n}\n\nasync function setPending(phone: string, state: PendingState): Promise {\n await blob.setJSON(pendingKey(phone), state);\n}\n\nasync function clearPending(phone: string): Promise {\n await blob.delete(pendingKey(phone));\n}\n\nfunction formatConfirmation(extracted: ExtractedEvent, link: string): string {\n const timePart = extracted.start_time ? ` ${extracted.start_time}` : \"\";\n const lines = [\n `✓ ${extracted.title} [${extracted.event_type}] — ${extracted.start_date}${timePart}`,\n ];\n if (extracted.location) lines.push(`📍 ${extracted.location}`);\n const priceBits: string[] = [];\n if (extracted.tickets_required) priceBits.push(\"🎟 tickets required\");\n if (extracted.price) priceBits.push(extracted.price);\n if (priceBits.length) lines.push(priceBits.join(\" · \"));\n lines.push(link);\n return lines.join(\"\\n\");\n}\n\nexport default async function (req: Request): Promise {\n if (req.method !== \"POST\") return new Response(\"POST only\", { status: 405 });\n\n const rawBody = await req.text();\n const signature = req.headers.get(\"x-twilio-signature\") ?? \"\";\n const ok = await verifyTwilioSignature(req.url, rawBody, signature);\n if (!ok) return new Response(\"invalid signature\", { status: 403 });\n\n const params = new URLSearchParams(rawBody);\n const from = (params.get(\"From\") ?? \"\").trim();\n const body = (params.get(\"Body\") ?? \"\").trim();\n\n const allowed = env(\"ALLOWED_NUMBERS\").split(\",\").map((s) => s.trim()).filter(\n Boolean,\n );\n if (!allowed.includes(from)) {\n return twiml(\"This number isn't on the fun-cal allowlist. Ignored.\");\n }\n if (!body) {\n return twiml(\n \"Empty message. Send event details (e.g. 'concert thursday 7pm at the bowery').\",\n );\n }\n\n const tz = env(\"TIMEZONE\");\n\n try {\n const pending = await getPending(from);\n if (pending) {\n const update = await extractDateUpdate(body, tz, pending.title);\n const patched = await patchEventDate(pending.eventId, update, tz);\n await clearPending(from);\n return twiml(\n `✓ Updated \"${pending.title}\" → ${update.start_date}${\n update.start_time ? ` ${update.start_time}` : \"\"\n }\\n${patched.htmlLink}`,\n );\n }\n\n const extracted = await extractEvent(body, tz);\n const created = await createEvent(extracted, body, tz);\n\n if (extracted.confidence === \"low\") {\n await setPending(from, {\n eventId: created.id,\n title: extracted.title,\n createdAt: Date.now(),\n });\n return twiml(\n `⚠️ Added \"${extracted.title}\" with placeholder date ${extracted.start_date}. Reply with the correct date/time and I'll fix it.\\n${created.htmlLink}`,\n );\n }\n return twiml(formatConfirmation(extracted, created.htmlLink));\n } catch (e) {\n return twiml(`Error: ${(e as Error).message ?? String(e)}`);\n }\n}","// fun-cal SMS endpoint.\n//\n// Twilio webhook (application/x-www-form-urlencoded) → calendar event in the \"Maybe\" calendar.\n//\n// Flow:\n// 1. Verify Twilio signature (HMAC-SHA1).\n// 2. Allowlist the From number.\n// 3. If a pending-clarification exists for this number: treat the new SMS as a date update,\n// patch the existing calendar event, clear pending state, reply.\n// 4. Otherwise: extract event from message body (+ optional URL fetch), create calendar event.\n// - high/medium confidence → reply with link, done.\n// - low confidence → reply asking for the correct date, store pending state.\n//\n// Env vars (set as Val.town secrets):\n// ANTHROPIC_API_KEY\n// GOOGLE_CLIENT_ID\n// GOOGLE_CLIENT_SECRET\n// GOOGLE_REFRESH_TOKEN\n// GOOGLE_CALENDAR_ID\n// TIMEZONE IANA tz, e.g. America/New_York\n// TWILIO_AUTH_TOKEN for signature verification\n// ALLOWED_NUMBERS comma-separated E.164 list, e.g. \"+15551234567,+15557654321\"\n\nimport { blob } from \"https://esm.town/v/std/blob\";\n\nconst env = (k: string): string => {\n const v = (globalThis as any).Deno?.env?.get?.(k) ??\n (globalThis as any).process?.env?.[k];\n if (!v) throw new Error(`Missing env var: ${k}`);\n return v;\n};\n\nconst PENDING_TTL_MS = 60 * 60 * 1000; // 1 hour\n\ntype EventType =\n | \"comedy\"\n | \"movie\"\n | \"performance\"\n | \"party\"\n | \"class\"\n | \"dinner\"\n | \"outdoor\"\n | \"other\";\n\ntype ExtractedEvent = {\n title: string;\n start_date: string;\n start_time: string | null;\n end_time: string | null;\n location: string;\n notes: string;\n confidence: \"high\" | \"medium\" | \"low\";\n event_type: EventType;\n tickets_required: boolean;\n price: string;\n ticket_url: string;\n};\n\nconst EVENT_COLOR: Record = {\n comedy: \"6\", // tangerine\n movie: \"8\", // graphite\n performance: \"9\", // blueberry\n party: \"11\", // tomato\n class: \"2\", // sage\n dinner: \"7\", // peacock\n outdoor: \"10\", // basil\n other: undefined, // default calendar color\n};\n\ntype PendingState = {\n eventId: string;\n title: string;\n createdAt: number;\n};\n\nasync function verifyTwilioSignature(\n url: string,\n body: string,\n signature: string,\n): Promise {\n const params = new URLSearchParams(body);\n const sortedKeys = [...new Set(params.keys())].sort();\n let data = url;\n for (const k of sortedKeys) data += k + params.get(k);\n\n const enc = new TextEncoder();\n const key = await crypto.subtle.importKey(\n \"raw\",\n enc.encode(env(\"TWILIO_AUTH_TOKEN\")),\n { name: \"HMAC\", hash: \"SHA-1\" },\n false,\n [\"sign\"],\n );\n const sig = await crypto.subtle.sign(\"HMAC\", key, enc.encode(data));\n const computed = btoa(String.fromCharCode(...new Uint8Array(sig)));\n return computed === signature;\n}\n\nfunction twiml(message: string): Response {\n const escaped = message.replace(/&/g, \"&\").replace(//g,\n \">\",\n );\n return new Response(\n `${escaped}`,\n { headers: { \"content-type\": \"text/xml; charset=utf-8\" } },\n );\n}\n\nfunction extractUrls(text: string): string[] {\n const re = /https?:\\/\\/[^\\s]+/g;\n return text.match(re) ?? [];\n}\n\nasync function fetchUrlText(url: string): Promise {\n try {\n const r = await fetch(url, {\n signal: AbortSignal.timeout(8000),\n headers: { \"user-agent\": \"Mozilla/5.0 (compatible; fun-cal/1.0)\" },\n redirect: \"follow\",\n });\n if (!r.ok) return \"\";\n const ct = r.headers.get(\"content-type\") ?? \"\";\n if (!ct.includes(\"text/html\") && !ct.includes(\"text/plain\")) return \"\";\n const html = await r.text();\n\n const structured: string[] = [];\n\n const titleMatch = html.match(/]*>([^<]+)<\\/title>/i);\n if (titleMatch) structured.push(`Page title: ${titleMatch[1].trim()}`);\n\n const metaTags: string[] = [];\n const metaRe = /]+>/gi;\n let mm: RegExpExecArray | null;\n while ((mm = metaRe.exec(html)) !== null) {\n const tag = mm[0];\n const nameMatch = tag.match(/(?:name|property)=[\"']([^\"']+)[\"']/i);\n const contentMatch = tag.match(/content=[\"']([^\"']*)[\"']/i);\n if (\n nameMatch && contentMatch &&\n /^(og:|twitter:|description$)/i.test(nameMatch[1])\n ) {\n metaTags.push(`${nameMatch[1]}: ${contentMatch[1]}`);\n }\n }\n if (metaTags.length) structured.push(\"Meta tags:\\n\" + metaTags.join(\"\\n\"));\n\n const jsonLdRe =\n /]*type=[\"']application\\/ld\\+json[\"'][^>]*>([\\s\\S]*?)<\\/script>/gi;\n let jm: RegExpExecArray | null;\n const ldBlocks: string[] = [];\n while ((jm = jsonLdRe.exec(html)) !== null) ldBlocks.push(jm[1].trim());\n if (ldBlocks.length) {\n structured.push(\"JSON-LD:\\n\" + ldBlocks.join(\"\\n---\\n\"));\n }\n\n const stripped = html\n .replace(//gi, \" \")\n .replace(//gi, \" \")\n .replace(/<[^>]+>/g, \" \")\n .replace(/ /g, \" \")\n .replace(/\\s+/g, \" \")\n .trim();\n\n const structuredPart = structured.length\n ? structured.join(\"\\n\\n\") + \"\\n\\n\"\n : \"\";\n const budget = 12000 - structuredPart.length;\n return (structuredPart + \"Page text:\\n\" + stripped).slice(\n 0,\n structuredPart.length + Math.max(0, budget),\n );\n } catch {\n return \"\";\n }\n}\n\nasync function callClaude(\n systemAndUser: { system?: string; user: string },\n tool: any,\n): Promise {\n const resp = await fetch(\"https://api.anthropic.com/v1/messages\", {\n method: \"POST\",\n headers: {\n \"x-api-key\": env(\"ANTHROPIC_API_KEY\"),\n \"anthropic-version\": \"2023-06-01\",\n \"content-type\": \"application/json\",\n },\n body: JSON.stringify({\n model: \"claude-sonnet-4-6\",\n max_tokens: 1024,\n ...(systemAndUser.system ? { system: systemAndUser.system } : {}),\n tools: [tool],\n tool_choice: { type: \"tool\", name: tool.name },\n messages: [{ role: \"user\", content: systemAndUser.user }],\n }),\n });\n if (!resp.ok) {\n throw new Error(`Anthropic ${resp.status}: ${await resp.text()}`);\n }\n const data = await resp.json() as {\n content: { type: string; input?: any }[];\n };\n const t = data.content.find((c) => c.type === \"tool_use\");\n if (!t?.input) {\n throw new Error(`No tool_use in response: ${JSON.stringify(data)}`);\n }\n return t.input;\n}\n\nasync function extractEvent(text: string, tz: string): Promise {\n const today = new Date().toLocaleDateString(\"en-CA\", { timeZone: tz });\n const urls = extractUrls(text);\n let augmented = text;\n if (urls.length) {\n const fetched = await fetchUrlText(urls[0]);\n if (fetched) augmented += `\\n\\n--- contents of ${urls[0]} ---\\n${fetched}`;\n }\n return await callClaude({\n user:\n `Extract event details from the source below. Today's date is ${today} (${tz}). If no date is clearly stated, set start_date to today and confidence to \"low\" — a human will fix it. Prefer dates in the future when ambiguous. The source may include structured data (JSON-LD, OpenGraph meta tags) — when present, these contain the most authoritative info; prefer them over text inferred from stripped HTML.\\n\\nFor event_type, classify into the closest of: comedy, movie, performance, party, class, dinner, outdoor, other. Use \"performance\" for concerts, plays, shows, dance, theater, sports games. Use \"party\" for social gatherings, hangouts, bar nights, drinks, celebrations. Use \"class\" for workshops, lectures, courses, educational events, anything you'd \"learn\" at. Use \"dinner\" for restaurant outings, food-focused events, dinner parties, food tours. Use \"outdoor\" for hikes, runs, picnics, beach days, sports played (not watched), camping. Use \"other\" only when nothing else fits.\\n\\nFor price, extract a short human-readable string like \"Free\", \"$25\", \"$50-100\", or \"\" if not stated.\\n\\nFor ticket_url, only fill in when there's a distinct buy/RSVP link different from the source URL; otherwise \"\".\\n\\nSource:\\n${augmented}`,\n }, {\n name: \"create_event\",\n description: \"Extract a calendar event from the provided text.\",\n input_schema: {\n type: \"object\",\n properties: {\n title: { type: \"string\" },\n start_date: { type: \"string\", description: \"ISO date YYYY-MM-DD\" },\n start_time: {\n type: [\"string\", \"null\"],\n description: \"24h HH:MM, or null for all-day\",\n },\n end_time: { type: [\"string\", \"null\"] },\n location: { type: \"string\" },\n notes: { type: \"string\", description: \"One-to-two sentence summary.\" },\n confidence: { type: \"string\", enum: [\"high\", \"medium\", \"low\"] },\n event_type: {\n type: \"string\",\n enum: [\n \"comedy\",\n \"movie\",\n \"performance\",\n \"party\",\n \"class\",\n \"dinner\",\n \"outdoor\",\n \"other\",\n ],\n },\n tickets_required: {\n type: \"boolean\",\n description:\n \"True if attendance requires a ticket/RSVP/registration.\",\n },\n price: {\n type: \"string\",\n description:\n \"Short price string like 'Free', '$25', '$50-100', or '' if unknown.\",\n },\n ticket_url: {\n type: \"string\",\n description:\n \"Direct buy/RSVP URL distinct from the source URL, or '' if none.\",\n },\n },\n required: [\n \"title\",\n \"start_date\",\n \"start_time\",\n \"end_time\",\n \"location\",\n \"notes\",\n \"confidence\",\n \"event_type\",\n \"tickets_required\",\n \"price\",\n \"ticket_url\",\n ],\n },\n });\n}\n\nasync function extractDateUpdate(\n text: string,\n tz: string,\n originalTitle: string,\n): Promise<\n { start_date: string; start_time: string | null; end_time: string | null }\n> {\n const today = new Date().toLocaleDateString(\"en-CA\", { timeZone: tz });\n return await callClaude({\n user:\n `The user is clarifying the date/time for an existing event titled \"${originalTitle}\". Today is ${today} (${tz}). Extract a concrete date/time from their reply.\\n\\nReply:\\n${text}`,\n }, {\n name: \"update_date\",\n description: \"Extract a date/time clarification.\",\n input_schema: {\n type: \"object\",\n properties: {\n start_date: { type: \"string\", description: \"ISO date YYYY-MM-DD\" },\n start_time: {\n type: [\"string\", \"null\"],\n description: \"24h HH:MM, or null for all-day\",\n },\n end_time: { type: [\"string\", \"null\"] },\n },\n required: [\"start_date\", \"start_time\", \"end_time\"],\n },\n });\n}\n\nasync function getGoogleAccessToken(): Promise {\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: env(\"GOOGLE_CLIENT_ID\"),\n client_secret: env(\"GOOGLE_CLIENT_SECRET\"),\n refresh_token: env(\"GOOGLE_REFRESH_TOKEN\"),\n grant_type: \"refresh_token\",\n }),\n });\n if (!resp.ok) {\n throw new Error(`Google token ${resp.status}: ${await resp.text()}`);\n }\n return (await resp.json() as { access_token: string }).access_token;\n}\n\nfunction addHour(hhmm: string): string {\n const [h, m] = hhmm.split(\":\").map(Number);\n const t = (h + 1) * 60 + m;\n return `${String(Math.floor((t / 60) % 24)).padStart(2, \"0\")}:${\n String(t % 60).padStart(2, \"0\")\n }`;\n}\n\nfunction startEndPayload(\n date: string,\n start_time: string | null,\n end_time: string | null,\n tz: string,\n) {\n if (start_time) {\n return {\n start: { dateTime: `${date}T${start_time}:00`, timeZone: tz },\n end: {\n dateTime: `${date}T${end_time ?? addHour(start_time)}:00`,\n timeZone: tz,\n },\n };\n }\n return { start: { date }, end: { date } };\n}\n\nasync function createEvent(\n extracted: ExtractedEvent,\n sourceText: string,\n tz: string,\n): Promise<{ htmlLink: string; id: string }> {\n const accessToken = await getGoogleAccessToken();\n const calId = env(\"GOOGLE_CALENDAR_ID\");\n const flag = extracted.confidence === \"low\"\n ? \"⚠️ Date unclear — text to fix\\n\\n\"\n : \"\";\n const urls = extractUrls(sourceText);\n\n const metaLines: string[] = [];\n metaLines.push(`Type: ${extracted.event_type}`);\n metaLines.push(\n `Tickets required: ${extracted.tickets_required ? \"Yes\" : \"No\"}`,\n );\n if (extracted.price) metaLines.push(`Price: ${extracted.price}`);\n if (extracted.ticket_url) metaLines.push(`Tickets: ${extracted.ticket_url}`);\n if (urls.length) metaLines.push(`Source: ${urls[0]}`);\n\n const description = `${flag}${extracted.notes}\\n\\n${\n metaLines.join(\"\\n\")\n }\\n\\n— captured via fun-cal SMS\\n\\nOriginal text:\\n${sourceText}`;\n\n const colorId = EVENT_COLOR[extracted.event_type];\n\n const extendedProps: Record = {\n event_type: extracted.event_type,\n tickets_required: String(extracted.tickets_required),\n price: extracted.price,\n ticket_url: extracted.ticket_url,\n confidence: extracted.confidence,\n source_url: urls[0] ?? \"\",\n captured_via: \"fun-cal-sms\",\n captured_at: new Date().toISOString(),\n };\n\n const resp = await fetch(\n `https://www.googleapis.com/calendar/v3/calendars/${\n encodeURIComponent(calId)\n }/events`,\n {\n method: \"POST\",\n headers: {\n authorization: `Bearer ${accessToken}`,\n \"content-type\": \"application/json\",\n },\n body: JSON.stringify({\n summary: extracted.title,\n location: extracted.location || undefined,\n description,\n extendedProperties: { private: extendedProps },\n ...(colorId ? { colorId } : {}),\n ...startEndPayload(\n extracted.start_date,\n extracted.start_time,\n extracted.end_time,\n tz,\n ),\n }),\n },\n );\n if (!resp.ok) {\n throw new Error(`Calendar insert ${resp.status}: ${await resp.text()}`);\n }\n return await resp.json() as { htmlLink: string; id: string };\n}\n\nasync function patchEventDate(\n eventId: string,\n update: {\n start_date: string;\n start_time: string | null;\n end_time: string | null;\n },\n tz: string,\n): Promise<{ htmlLink: string }> {\n const accessToken = await getGoogleAccessToken();\n const calId = env(\"GOOGLE_CALENDAR_ID\");\n const resp = await fetch(\n `https://www.googleapis.com/calendar/v3/calendars/${\n encodeURIComponent(calId)\n }/events/${encodeURIComponent(eventId)}`,\n {\n method: \"PATCH\",\n headers: {\n authorization: `Bearer ${accessToken}`,\n \"content-type\": \"application/json\",\n },\n body: JSON.stringify(\n startEndPayload(\n update.start_date,\n update.start_time,\n update.end_time,\n tz,\n ),\n ),\n },\n );\n if (!resp.ok) {\n throw new Error(`Calendar patch ${resp.status}: ${await resp.text()}`);\n }\n return await resp.json() as { htmlLink: string };\n}\n\nfunction pendingKey(phone: string): string {\n return `funcal:pending:${phone}`;\n}\n\nasync function getPending(phone: string): Promise {\n const v = await blob.getJSON(pendingKey(phone)) as PendingState | null;\n if (!v) return null;\n if (Date.now() - v.createdAt > PENDING_TTL_MS) {\n await blob.delete(pendingKey(phone));\n return null;\n }\n return v;\n}\n\nasync function setPending(phone: string, state: PendingState): Promise {\n await blob.setJSON(pendingKey(phone), state);\n}\n\nasync function clearPending(phone: string): Promise {\n await blob.delete(pendingKey(phone));\n}\n\nfunction formatConfirmation(extracted: ExtractedEvent, link: string): string {\n const timePart = extracted.start_time ? ` ${extracted.start_time}` : \"\";\n const lines = [\n `✓ ${extracted.title} [${extracted.event_type}] — ${extracted.start_date}${timePart}`,\n ];\n if (extracted.location) lines.push(`📍 ${extracted.location}`);\n const priceBits: string[] = [];\n if (extracted.tickets_required) priceBits.push(\"🎟 tickets required\");\n if (extracted.price) priceBits.push(extracted.price);\n if (priceBits.length) lines.push(priceBits.join(\" · \"));\n lines.push(link);\n return lines.join(\"\\n\");\n}\n\nexport default async function (req: Request): Promise {\n if (req.method !== \"POST\") return new Response(\"POST only\", { status: 405 });\n\n const rawBody = await req.text();\n const signature = req.headers.get(\"x-twilio-signature\") ?? \"\";\n const ok = await verifyTwilioSignature(req.url, rawBody, signature);\n if (!ok) return new Response(\"invalid signature\", { status: 403 });\n\n const params = new URLSearchParams(rawBody);\n const from = (params.get(\"From\") ?? \"\").trim();\n const body = (params.get(\"Body\") ?? \"\").trim();\n\n const allowed = env(\"ALLOWED_NUMBERS\").split(\",\").map((s) => s.trim()).filter(\n Boolean,\n );\n if (!allowed.includes(from)) {\n return twiml(\"This number isn't on the fun-cal allowlist. Ignored.\");\n }\n if (!body) {\n return twiml(\n \"Empty message. Send event details (e.g. 'concert thursday 7pm at the bowery').\",\n );\n }\n\n const tz = env(\"TIMEZONE\");\n\n try {\n const pending = await getPending(from);\n if (pending) {\n const update = await extractDateUpdate(body, tz, pending.title);\n const patched = await patchEventDate(pending.eventId, update, tz);\n await clearPending(from);\n return twiml(\n `✓ Updated \"${pending.title}\" → ${update.start_date}${\n update.start_time ? ` ${update.start_time}` : \"\"\n }\\n${patched.htmlLink}`,\n );\n }\n\n const extracted = await extractEvent(body, tz);\n const created = await createEvent(extracted, body, tz);\n\n if (extracted.confidence === \"low\") {\n await setPending(from, {\n eventId: created.id,\n title: extracted.title,\n createdAt: Date.now(),\n });\n return twiml(\n `⚠️ Added \"${extracted.title}\" with placeholder date ${extracted.start_date}. Reply with the correct date/time and I'll fix it.\\n${created.htmlLink}`,\n );\n }\n return twiml(formatConfirmation(extracted, created.htmlLink));\n } catch (e) {\n return twiml(`Error: ${(e as Error).message ?? String(e)}`);\n }\n}","createdAt",["D",1779467666768],"branchVersion","branchId","92ae0876-54ad-11f1-af2b-ee650bb23af1","id","92ad269a-54ad-11f1-af2b-ee650bb23af1","funCalCapture",["D",1779323989208],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","for my fun cal capture","imageUrl","5a2ab9ee-83b9-4c20-ad32-f0f81377ac4b","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","019e47f5-ef11-74ed-9eea-0fc1333f6a49","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_95":94,"_103":99},"org",{"_95":94,"_96":97,"_98":99,"_18":55,"_100":101,"_102":25},"branch",{"_13":84,"_32":85,"_43":42,"_86":44,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":45,"_93":94},"isOwned",9,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","emmafrederick","handle","displayName","Emma Frederick","avatar","https://lh3.googleusercontent.com/a/ACg8ocKAfUWLgyIa6OumXM7xjCVgoj98LYMiWuOLYtpKWf4WsBJSLgc=s96-c","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_43":44,"_32":45,"_38":151,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":-5,"_57":25,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":-5,"_65":-5,"_66":-5,"_67":-5,"_68":69,"_70":69,"_71":72,"_73":72,"_74":72,"_75":69,"_76":69,"_77":152,"_79":153,"_81":154,"_83":25},"tree",[146],"files",[146],"counts",{"_135":61,"_136":137,"_138":61,"_139":140,"_141":142},"contents",[127],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles",true,"grants","orgs","customDomains",{},{"_43":128,"_32":28,"_30":31,"_129":-5,"_41":42,"_40":14,"_130":25,"_38":131,"_13":132,"_33":34,"_35":37,"_24":25,"_133":-5,"_27":134},"192f2160-55fc-11f1-aaa0-ee650bb23af1","parentId","latest",["D",1779467666768],7,"label",[28],"pulls","branches",1,"forks","envVars",{"_143":84,"_145":61},"connections",{"_143":61,"_144":61},"count","unfilledCount","emptyCount",{"_43":128,"_32":28,"_30":31,"_129":-5,"_41":42,"_40":14,"_130":25,"_38":147,"_13":132,"_33":34,"_35":37,"_24":25,"_133":-5,"_148":149,"_27":150},["D",1779467666768],"children",[],[28],["D",1779323989208],{"_95":94,"_103":99},{"_95":94,"_96":97,"_98":99,"_18":55,"_100":101,"_102":25},{"_13":84,"_32":85,"_43":42,"_86":44,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":45,"_93":94},"ctx",{"_77":-5,"_124":188,"_189":190,"_191":192,"_193":25,"_194":25,"_195":25,"_196":122,"_197":-5,"_198":-7,"_199":-7,"_200":61,"_201":25,"_202":25,"_203":-5,"_204":25,"_205":25,"_206":25,"_207":-5},"ENV",{"_159":160,"_161":162,"_163":85,"_164":165,"_166":167,"_168":169,"_170":171,"_172":173,"_174":175,"_176":177,"_178":179,"_180":181,"_182":183,"_184":185,"_186":187},"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 · v8