[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_201":202,"_203":204},"routes/_app.x.$handle.$name",{"_96":95,"_32":45,"_104":86,"_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":58,"_122":-5,"_123":-5,"_124":125},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_43":44,"_32":45,"_38":46,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":-5,"_53":-5,"_18":54,"_55":56,"_57":58,"_59":58,"_60":-5,"_61":62,"_63":64,"_65":-5,"_66":-5,"_67":-5,"_68":-5,"_69":70,"_71":70,"_72":73,"_74":73,"_75":73,"_76":70,"_77":70,"_78":79,"_80":81,"_82":83,"_84":25},"version",104,"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","email.ts","latestPath","fileId","b2731a10-6fb7-11f0-9f74-0224a6c84d84","name","fileType","email","content","export default async function (e: Email) {\n \n}","// interface Email {\n// from: string;\n// to: string[];\n// cc: string | string[] | undefined;\n// bcc: string | string[] | undefined;\n// subject: string | undefined;\n// text: string | undefined;\n// html: string | undefined;\n// attachments: File[];\n// }\nconst KNOWN_SENDERS = [\n 'josh@joshbeckman.org',\n];\nexport default async function (e: Email) {\n if (!KNOWN_SENDERS.includes(e.from)) {\n console.error('Unauthorized sender:', e.from);\n console.log(e);\n return;\n }\n const body = e.text || e.html || '';\n const toMatch = body.match(/To:\\s*([^\\n]+)/);\n await sqlite.execute({\n sql: `INSERT INTO personal_mcp_emails (subject, body, from_sender, to_recipient, reply_to) VALUES (?, ?, ?, ?, ?)`,\n args: [e.subject || '', body, e.from, toMatch ? toMatch[1] : '', e.replyTo || e.from],\n });\n}\n","createdAt",["D",1754149890377],"branchVersion","branchId","c4f3237c-62b7-11f0-b65c-0224a6c84d84","id","c4f2e6f0-62b7-11f0-b65c-0224a6c84d84","personal-mcp",["D",1752720187124],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","imageUrl","f8d90ec1-81be-4efc-b861-a032f3f5b85f","pinnedFileId","5ffab9e2-62b9-11f0-9d00-0224a6c84d84","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","b1ec36cc-9d04-4938-872f-34bf39599d6a","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_96":95,"_103":99},"org",{"_96":95,"_97":-5,"_98":99,"_18":54,"_100":101,"_102":25},"branch",{"_13":85,"_32":86,"_43":42,"_87":44,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":45,"_94":95},"isOwned",124,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","joshbeckman","handle","displayName","avatar","https://img.clerk.com/eyJ0eXBlIjoiZGVmYXVsdCIsImlpZCI6Imluc18yTm10cGhQUklwU0tqZHNiOHNnNGd2ZjJURFUiLCJyaWQiOiJ1c2VyXzJTZm1HaHJGdDFmQ2s5ME05RW9lT1JGbHZPYyIsImluaXRpYWxzIjoiSkIifQ","tier","pro","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_43":44,"_32":45,"_38":197,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":-5,"_53":-5,"_18":54,"_55":56,"_57":58,"_59":58,"_60":-5,"_61":62,"_63":64,"_65":-5,"_66":-5,"_67":-5,"_68":-5,"_69":70,"_71":70,"_72":73,"_74":73,"_75":73,"_76":70,"_77":70,"_78":198,"_80":199,"_82":200,"_84":25},"tree",[171,173,174,175],"files",[171,172,173,174,175],"counts",{"_159":62,"_160":161,"_162":62,"_163":164,"_165":166},"contents",[126,127,128,129],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_43":152,"_32":153,"_30":154,"_132":-5,"_41":42,"_40":155,"_134":58,"_38":156,"_13":62,"_33":157,"_35":-5,"_24":25,"_139":-5,"_27":158},{"_43":146,"_32":147,"_30":148,"_132":-5,"_41":42,"_40":143,"_134":58,"_38":149,"_13":62,"_33":20,"_35":150,"_24":25,"_139":-5,"_27":151},{"_43":141,"_32":28,"_30":31,"_132":-5,"_41":42,"_40":14,"_134":25,"_38":142,"_13":143,"_33":34,"_35":37,"_24":25,"_139":144,"_27":145},{"_43":130,"_32":131,"_30":56,"_132":-5,"_41":42,"_40":133,"_134":25,"_38":135,"_13":136,"_33":137,"_35":138,"_24":25,"_139":-5,"_27":140},"e3b6d6a4-6fb5-11f0-878f-0224a6c84d84","main.ts","parentId",99,"latest",["D",1754148744854],68,"http","import { Hono } from 'npm:hono';\nimport { toFetchResponse, toReqRes } from \"npm:fetch-to-node\";\nimport { z } from \"npm:zod@3.25.75\";\nimport { StreamableHTTPServerTransport } from \"npm:@modelcontextprotocol/sdk@1.16.0/server/streamableHttp.js\";\nimport { McpServer, ResourceTemplate } from \"npm:@modelcontextprotocol/sdk@1.16.0/server/mcp.js\";\nimport { email } from \"https://esm.town/v/std/email\";\nimport { blob } from \"https://esm.town/v/std/blob\";\nimport { sqlite } from \"https://esm.town/v/std/sqlite\";\n\nconst app = new Hono();\n\n// Storage keys\nconst STORAGE_KEY = \"personal_mcp\";\nconst SERVER_VERSION = \"1.2.0\";\nconst FIELDS = [\n \"about\",\n \"age\",\n \"status\",\n \"timezone\",\n];\n\n// Custom Zod schema for username validation\nconst usernameSchema = z.string()\n .min(1, \"Username cannot be empty\")\n .max(39, \"Username must be 39 characters or less\")\n .regex(/^[a-zA-Z0-9][a-zA-Z0-9._-]*[a-zA-Z0-9]$/, \"Username must start and end with alphanumeric characters, and can contain letters, numbers, dots, underscores, and hyphens\");\n// Get environment variables\nconst READ_PASSWORD = Deno.env.get(\"READ_PASSWORD\") || \"read123\";\nconst WRITE_PASSWORD = Deno.env.get(\"WRITE_PASSWORD\") || \"write123\";\nconst JINA_AI_TOKEN = Deno.env.get(\"JINA_AI_TOKEN\");\nconst VONAGE_API_KEY = Deno.env.get(\"VONAGE_API_KEY\");\nconst VONAGE_API_SECRET = Deno.env.get(\"VONAGE_API_SECRET\");\nconst VONAGE_FROM_NUMBER = Deno.env.get(\"VONAGE_FROM_NUMBER\");\nconst JOSH_PHONE_NUMBER = Deno.env.get(\"JOSH_PHONE_NUMBER\");\n\n// Initialize default values if they don't exist\nasync function initializeStorage() {\n const existing = await blob.getJSON(STORAGE_KEY);\n if (!existing) {\n const defaultValues: Record = {};\n FIELDS.forEach(field => {\n if (field === \"status\") {\n defaultValues[field] = Math.random() > 0.5 ? \"active\" : \"inactive\";\n } else {\n defaultValues[field] = \"\";\n }\n });\n await blob.setJSON(STORAGE_KEY, defaultValues);\n }\n}\n\n// Initialize SQLite tables for message tracking\nasync function initializeDatabase() {\n await Promise.all([\n sqlite.execute(`\n CREATE TABLE IF NOT EXISTS personal_mcp_emails (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n subject TEXT NOT NULL,\n body TEXT NOT NULL,\n from_sender TEXT NOT NULL,\n to_recipient TEXT NOT NULL,\n reply_to TEXT,\n sent_at DATETIME DEFAULT CURRENT_TIMESTAMP\n )\n `),\n sqlite.execute(`\n CREATE TABLE IF NOT EXISTS personal_mcp_sms_messages (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n body TEXT NOT NULL,\n from_sender TEXT NOT NULL,\n to_recipient TEXT NOT NULL,\n sent_at DATETIME DEFAULT CURRENT_TIMESTAMP\n )\n `)\n ]);\n if (Math.random() < 0.5) {\n return; // 50% chance to skip cleanup\n }\n // Clean up old entries (older than 2 weeks) in parallel\n const twoWeeksAgo = new Date();\n twoWeeksAgo.setDate(twoWeeksAgo.getDate() - 14);\n const cutoffDate = twoWeeksAgo.toISOString();\n await Promise.all([\n sqlite.execute({\n sql: `DELETE FROM personal_mcp_emails WHERE sent_at < ?`,\n args: [cutoffDate]\n }),\n sqlite.execute({\n sql: `DELETE FROM personal_mcp_sms_messages WHERE sent_at < ?`,\n args: [cutoffDate]\n })\n ]);\n}\n\n// Helper function to get current values\nasync function getValues() {\n await initializeStorage();\n return await blob.getJSON(STORAGE_KEY);\n}\n\n// Helper function to update values\nasync function updateValues(newValues: Record) {\n const current = await getValues();\n const updated = { ...current, ...newValues, updated_at: new Date().toISOString() };\n await blob.setJSON(STORAGE_KEY, updated);\n return updated;\n}\n\n// Helper function to build time string for a given timezone\nfunction buildTimeString(timezone: string): string {\n const date = new Date();\n const options: Intl.DateTimeFormatOptions = {\n timeZone: timezone,\n year: 'numeric',\n month: '2-digit',\n day: '2-digit',\n hour: '2-digit',\n minute: '2-digit',\n second: '2-digit',\n };\n return date.toLocaleString('sv-SE', options);\n}\n\n// Helper function to get part of day based on timezone\nfunction getPartOfDay(timezone: string): string {\n const date = new Date();\n const options: Intl.DateTimeFormatOptions = {\n timeZone: timezone,\n hour: 'numeric',\n hour12: false,\n };\n const hours = parseInt(date.toLocaleTimeString('en-US', options));\n if (hours < 6) {\n return \"night\";\n } else if (hours < 12) {\n return \"morning\";\n } else if (hours < 18) {\n return \"afternoon\";\n } else {\n return \"evening\";\n }\n}\n\nfunction timeRelative(date) {\n var now = new Date();\n var seconds = Math.floor((now - date) / 1000);\n var minutes = Math.floor(seconds / 60);\n var hours = Math.floor(minutes / 60);\n var days = Math.floor(hours / 24);\n var months = Math.floor(days / 30);\n var years = Math.floor(months / 12);\n\n // Handle future times\n if (seconds < 0) {\n seconds = Math.abs(seconds);\n minutes = Math.abs(minutes);\n hours = Math.abs(hours);\n days = Math.abs(days);\n months = Math.abs(months);\n years = Math.abs(years);\n\n if (minutes < 1) {\n return \"in a moment\";\n } else if (minutes < 2) {\n return \"in a minute\";\n } else if (hours < 1) {\n return \"in \" + minutes + \" minutes\";\n } else if (hours < 2) {\n return \"in an hour\";\n } else if (days < 1) {\n return \"in \" + hours + \" hours\";\n } else if (days < 2) {\n return \"tomorrow\";\n } else if (days < 7) {\n return \"in \" + days + \" days\";\n } else if (days < 14) {\n return \"next week\";\n } else if (months < 1) {\n return \"in \" + days + \" days\";\n } else if (months < 2) {\n return \"next month\";\n } else if (years < 1) {\n return \"in \" + months + \" months\";\n } else if (years < 2) {\n return \"next year\";\n } else if (years < 10) {\n return \"in \" + years + \" years\";\n } else {\n return date.toLocaleDateString();\n }\n }\n\n // Handle past times (existing logic)\n if (minutes < 1) {\n return \"just now\";\n } else if (minutes < 2) {\n return \"a minute ago\";\n } else if (hours < 1) {\n return minutes + \" minutes ago\";\n } else if (hours < 2) {\n return \"an hour ago\";\n } else if (days < 1) {\n return hours + \" hours ago\";\n } else if (days < 2) {\n return \"yesterday\";\n } else if (days < 7) {\n return days + \" days ago\";\n } else if (days < 14) {\n return \"last week\";\n } else if (months < 1) {\n return days + \" days ago\";\n } else if (months < 2) {\n return \"last month\";\n } else if (years < 1) {\n return months + \" months ago\";\n } else if (years < 2) {\n return \"last year\";\n } else if (years < 10) {\n return years + \" years ago\";\n } else {\n return date.toLocaleDateString();\n }\n}\n\n// Helper function to get granular season based on timezone and current date\nfunction getSeason(timezone: string): string {\n const date = new Date();\n const options: Intl.DateTimeFormatOptions = {\n timeZone: timezone,\n month: 'numeric',\n day: 'numeric',\n };\n const localDate = date.toLocaleDateString('en-US', options);\n const [month, day] = localDate.split('/').map(Number);\n // Calculate day of year for more granular seasons\n const dayOfYear = Math.floor((date.getTime() - new Date(date.getFullYear(), 0, 0).getTime()) / (1000 * 60 * 60 * 24));\n // 13 granular seasons mapped to approximate day ranges (365 days / 13 ≈ 28 days each)\n if (dayOfYear <= 28) return \"New Year\";\n else if (dayOfYear <= 56) return \"Frozen Winter\";\n else if (dayOfYear <= 84) return \"Winter\";\n else if (dayOfYear <= 112) return \"Early Spring\";\n else if (dayOfYear <= 140) return \"Wet Spring\";\n else if (dayOfYear <= 168) return \"Spring\";\n else if (dayOfYear <= 196) return \"Breaking Summer\";\n else if (dayOfYear <= 224) return \"Summer\";\n else if (dayOfYear <= 252) return \"Hot Summer\";\n else if (dayOfYear <= 280) return \"Early Autumn\";\n else if (dayOfYear <= 308) return \"Autumn\";\n else if (dayOfYear <= 336) return \"Closing Autumn\";\n else return \"Early Winter\";\n}\n\n// Helper function to get about information from jina.ai\nasync function getAbout(): Promise {\n if (!JINA_AI_TOKEN) {\n return \"No JINA_AI_TOKEN available\";\n }\n try {\n const response = await fetch(\"https://r.jina.ai/https://www.joshbeckman.org/about/\", {\n headers: {\n \"Authorization\": `Bearer ${JINA_AI_TOKEN}`\n }\n });\n if (!response.ok) {\n return `Error fetching about information: ${response.status} ${response.statusText}`;\n }\n return await response.text();\n } catch (error) {\n return `Error fetching about information: ${error.message}`;\n }\n}\n\n// Main HTML page (requires read password)\napp.get(\"/\", async (c) => {\n const password = c.req.query(\"password\");\n if (password !== READ_PASSWORD) {\n return c.html(`\n \n \n \n Password Required\n \n \n \n \n \n

Enter Password

\n \n

\n \n \n `);\n }\n\n // Password is correct, show the main page\n const values = await getValues();\n return c.html(`\n \n \n \n Key/Value Store\n \n \n \n \n \n

Key/Value Store

\n \n

Current Values

\n \n \n \n \n \n \n \n \n ${FIELDS.map(field => `\n \n \n \n \n `).join('')}\n \n

Key	Value
${field}	${values[field] \|\| ''}

\n \n

Update Values

\n \n

\n \n \n `);\n});\n\n// Handle form submission to update values\napp.post(\"/update\", async (c) => {\n const formData = await c.req.formData();\n const writePassword = formData.get(\"write_password\") as string;\n\n if (writePassword !== WRITE_PASSWORD) {\n return c.html(`\n \n \n \n Error\n \n \n \n \n \n

Error

Invalid write password.

\n Go Back\n

\n \n \n `);\n }\n\n // Collect values for all fields\n const updateData: Record = {};\n FIELDS.forEach(field => {\n const value = formData.get(field) as string;\n if (value !== null) {\n updateData[field] = value;\n }\n });\n\n // Fetch fresh about information from jina.ai\n const aboutText = await getAbout();\n updateData.about = aboutText;\n\n // Update the values\n await updateValues(updateData);\n\n // Redirect back to main page\n return new Response(null, {\n status: 302,\n headers: { Location: `/?password=${READ_PASSWORD}` }\n });\n});\n\n// JSON API endpoint (requires Bearer token)\napp.get(\"/api\", async (c) => {\n const authHeader = c.req.header(\"Authorization\");\n if (!authHeader || !authHeader.startsWith(\"Bearer \")) {\n return c.json({ error: \"Missing or invalid Authorization header\" }, 401);\n }\n\n const token = authHeader.substring(7); // Remove \"Bearer \" prefix\n if (token !== READ_PASSWORD) {\n return c.json({ error: \"Invalid token\" }, 401);\n }\n\n const values = await getValues();\n const partOfDay = getPartOfDay(values.timezone || \"UTC\");\n const timeString = buildTimeString(values.timezone || \"UTC\");\n const season = getSeason(values.timezone || \"UTC\");\n return c.json({\n ...values,\n part_of_day: partOfDay,\n time: timeString,\n season,\n version: SERVER_VERSION,\n });\n});\n\napp.post(\"/mcp\", async (c) => {\n const { req, res } = toReqRes(c.req.raw);\n\n const authHeader = c.req.header(\"Authorization\");\n if (!authHeader || !authHeader.startsWith(\"Bearer \")) {\n return c.json(\n {\n jsonrpc: \"2.0\",\n error: {\n code: -32603,\n message: \"Authorization header is required\",\n },\n id: null,\n },\n { status: 401 }\n );\n }\n\n const token = authHeader.substring(7); // Remove \"Bearer \" prefix\n if (token !== READ_PASSWORD) {\n return c.json(\n {\n jsonrpc: \"2.0\",\n error: {\n code: -32603,\n message: \"Invalid authorization token\",\n },\n id: null,\n },\n { status: 403 }\n );\n }\n\n try {\n const transport: StreamableHTTPServerTransport =\n new StreamableHTTPServerTransport({\n sessionIdGenerator: undefined,\n });\n\n // Added for extra debuggability\n transport.onerror = console.error.bind(console);\n\n await mcpServer.connect(transport);\n await transport.handleRequest(req, res, await c.req.json());\n\n res.on(\"close\", () => {\n transport.close();\n mcpServer.close();\n });\n\n return toFetchResponse(res);\n } catch (e) {\n console.error(e);\n return c.json(\n {\n jsonrpc: \"2.0\",\n error: {\n code: -32603,\n message: \"Internal server error\",\n },\n id: null,\n },\n { status: 500 }\n );\n }\n});\n\napp.get(\"/mcp\", async (c) => {\n console.log(`${new Date().toISOString()} Received GET MCP request`);\n return c.json(\n {\n jsonrpc: \"2.0\",\n error: {\n code: -32000,\n message: \"Method not allowed.\",\n },\n id: null,\n },\n { status: 405 }\n );\n});\n\napp.delete(\"/mcp\", async (c) => {\n console.log(`${new Date().toISOString()} Received DELETE MCP request`);\n return c.json(\n {\n jsonrpc: \"2.0\",\n error: {\n code: -32000,\n message: \"Method not allowed.\",\n },\n id: null,\n },\n { status: 405 }\n );\n});\n\nasync function setupMcpServer(): Promise {\n const server = new McpServer({\n name: \"Josh Beckman Personal State\",\n version: SERVER_VERSION,\n description: \"MCP server that provides current state and details of Josh Beckman.\",\n },\n { capabilities: { logging: {} } });\n\n try {\n server.registerTool(\n \"get_status\",\n {\n title: \"Josh Beckman's Status\",\n description: \"Get the latest status of Josh Beckman.\",\n inputSchema: {},\n },\n async () => {\n const values = await getValues();\n const updatedAt = values.updated_at ? `Updated ${timeRelative(new Date(values.updated_at))}` : \"\";\n return {\n content: [{ type: \"text\", text: `${values.status || \"No status available\"}\\n\\n${updatedAt}` }]\n };\n }\n );\n server.registerTool(\n \"get_age\",\n {\n title: \"Josh Beckman's Age\",\n description: \"Get the age of Josh Beckman.\",\n inputSchema: {},\n },\n async () => {\n const values = await getValues();\n return {\n content: [{ type: \"text\", text: values.age || \"No age information available\" }]\n };\n }\n );\n server.registerTool(\n \"get_about\",\n {\n title: \"About Josh Beckman\",\n description: \"Get basic information about Josh Beckman.\",\n inputSchema: {},\n },\n async () => {\n const values = await getValues();\n return {\n content: [{ type: \"text\", text: values.about || \"No about information available\" }]\n };\n }\n );\n server.registerTool(\n \"get_current_time_of_day\",\n {\n title: \"Current Time of Day for Josh Beckman\",\n description: \"Get the current time of day Josh Beckman is experiencing, including timezone, part of day, and season.\",\n inputSchema: {},\n },\n async () => {\n const values = await getValues();\n const timezone = values.timezone || \"UTC\";\n const timeString = buildTimeString(timezone);\n const partOfDay = getPartOfDay(timezone);\n const season = getSeason(timezone);\n return {\n content: [{ type: \"text\", text: `The current time for Josh (in ${timezone}) is ${timeString} and it's ${partOfDay}.\\nThe season is ${season}.` }]\n };\n }\n );\n server.registerTool(\n \"compare_time_relative\",\n {\n title: \"Time Relative to Josh Beckman\",\n description: \"Get the relative time from now to a given timestamp in Josh Beckman's timezone.\",\n inputSchema: {\n timestamp: z.string().datetime(),\n },\n },\n async ({ timestamp }) => {\n const time = new Date(timestamp);\n if (isNaN(time.getTime())) {\n return {\n content: [{ type: \"text\", text: \"Invalid timestamp provided\" }]\n };\n }\n return {\n content: [{ type: \"text\", text: timeRelative(time) }]\n };\n }\n );\n server.registerTool(\n \"send_email_to_josh\",\n {\n title: \"Email Josh Beckman\",\n description: \"Send an email to Josh Beckman. The 'subject' is the email subject line to uniquely identify the topic. The 'body' is the email content in plain text (markdown syntax supported). The 'from' field should uniquely identify the sender (either an agent's handle or a human user's username/handle). The optional 'replyTo' field sets the reply-to email address for responses to have Josh respond directly rather than through this MCP server.\",\n inputSchema: {\n subject: z.string(),\n body: z.string(),\n from: usernameSchema,\n replyTo: z.string().email(\"Must be a valid email address\").optional(),\n },\n },\n async ({ subject, body, from, replyTo }) => {\n const emailBody = `${body}\\n\\nFrom: ${from}`;\n const emailOptions: any = {\n subject: subject,\n text: emailBody,\n };\n if (replyTo) {\n emailOptions.replyTo = replyTo;\n }\n await email(emailOptions);\n await sqlite.execute({\n sql: `INSERT INTO personal_mcp_emails (subject, body, from_sender, to_recipient, reply_to) VALUES (?, ?, ?, ?, ?)`,\n args: [subject, body, from, 'josh@joshbeckman.org', replyTo || null]\n });\n return {\n content: [{ type: \"text\", text: `Email \"${subject}\" sent successfully!\\n\\nFrom: ${from}${replyTo ? `\\nReply-To: ${replyTo}` : ''}` }]\n };\n }\n );\n server.registerTool(\n \"send_sms_text_to_josh\",\n {\n title: \"Text Josh Beckman\",\n description: \"Send a text message (SMS) to Josh Beckman's phone. The 'body' is the SMS text message content. The 'from' field should uniquely identify the sender (either an agent's handle or a human user's username/handle).\",\n inputSchema: {\n body: z.string().max(150, \"SMS messages should be 150 characters or less\"),\n from: usernameSchema,\n },\n },\n async ({ body, from }) => {\n if (!VONAGE_API_KEY || !VONAGE_API_SECRET || !VONAGE_FROM_NUMBER || !JOSH_PHONE_NUMBER) {\n return {\n content: [{ type: \"text\", text: \"Missing Vonage credentials or phone numbers. Please set VONAGE_API_KEY, VONAGE_API_SECRET, VONAGE_FROM_NUMBER, and JOSH_PHONE_NUMBER environment variables.\" }]\n };\n }\n\n try {\n const response = await fetch(\"https://rest.nexmo.com/sms/json\", {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/x-www-form-urlencoded\",\n },\n body: new URLSearchParams({\n api_key: VONAGE_API_KEY,\n api_secret: VONAGE_API_SECRET,\n from: VONAGE_FROM_NUMBER,\n to: JOSH_PHONE_NUMBER,\n text: `${from}:\\n\\n${body}`,\n }).toString(),\n });\n\n const result = await response.json();\n if (result.messages && result.messages[0] && result.messages[0].status === \"0\") {\n await sqlite.execute({\n sql: `INSERT INTO personal_mcp_sms_messages (body, from_sender, to_recipient) VALUES (?, ?, ?)`,\n args: [body, from, JOSH_PHONE_NUMBER]\n });\n return {\n content: [{ type: \"text\", text: `Text message sent successfully!\\n\\nFrom: ${from}\\nMessage ID: ${result.messages[0][\"message-id\"]}` }]\n };\n } else {\n const errorText = result.messages?.[0]?.[\"error-text\"] || \"Unknown error\";\n return {\n content: [{ type: \"text\", text: `Failed to send text message: ${errorText}` }]\n };\n }\n } catch (error) {\n return {\n content: [{ type: \"text\", text: `Error sending text message: ${error.message}` }]\n };\n }\n }\n );\n server.registerTool(\n \"search_josh_sms_responses\",\n {\n title: \"Search Josh's SMS Responses\",\n description: \"Search for SMS messages sent by Josh. The 'to' field should be the username of the recipient (either an agent's handle or a human user's username/handle). The 'body_contains' field is an optional search string to filter messages by content.\",\n inputSchema: {\n to: usernameSchema,\n body_contains: z.string().optional(),\n },\n },\n async ({ to, body_contains }) => {\n if (!JOSH_PHONE_NUMBER) {\n return {\n content: [{ type: \"text\", text: \"JOSH_PHONE_NUMBER not configured\" }]\n };\n }\n let sql = `SELECT * FROM personal_mcp_sms_messages WHERE from_sender = ? AND to_recipient = ?`;\n const args: any[] = [JOSH_PHONE_NUMBER, to];\n if (body_contains) {\n sql += ` AND body LIKE ?`;\n args.push(`%${body_contains}%`);\n }\n sql += ` ORDER BY sent_at DESC LIMIT 50`;\n try {\n const results = await sqlite.execute({ sql, args });\n if (!results.rows || results.rows.length === 0) {\n return {\n content: [{ type: \"text\", text: `No SMS messages found from Josh to ${to}${body_contains ? ` containing \"${body_contains}\"` : ''}` }]\n };\n }\n const messages = results.rows.map((row: any) => ({\n body: row[1],\n sent_at: row[4]\n }));\n let responseText = `Found ${messages.length} SMS message${messages.length === 1 ? '' : 's'} from Josh to ${to}${body_contains ? ` containing \"${body_contains}\"` : ''}:\\n\\n`;\n messages.forEach((msg, index) => {\n responseText += `[${new Date(msg.sent_at).toLocaleString()}]\\n${msg.body}\\n`;\n if (index < messages.length - 1) responseText += '\\n---\\n\\n';\n });\n return {\n content: [{ type: \"text\", text: responseText }]\n };\n } catch (error) {\n return {\n content: [{ type: \"text\", text: `Error searching SMS messages: ${error.message}` }]\n };\n }\n }\n );\n server.registerTool(\n \"search_josh_email_responses\",\n {\n title: \"Search Josh's Email Responses\",\n description: \"Search for emails sent by Josh. The 'to' field should be the username of the recipient (either an agent's handle or a human user's username/handle). The 'body_contains' and 'subject_contains' fields are optional search strings to filter messages by content and subject.\",\n inputSchema: {\n to: usernameSchema,\n body_contains: z.string().optional(),\n subject_contains: z.string().optional(),\n },\n },\n async ({ to, body_contains, subject_contains }) => {\n let sql = `SELECT * FROM personal_mcp_emails WHERE from_sender = 'josh@joshbeckman.org' AND to_recipient = ?`;\n const args: any[] = [to];\n if (body_contains) {\n sql += ` AND body LIKE ?`;\n args.push(`%${body_contains}%`);\n }\n if (subject_contains) {\n sql += ` AND subject LIKE ?`;\n args.push(`%${subject_contains}%`);\n }\n sql += ` ORDER BY sent_at DESC LIMIT 50`;\n try {\n const results = await sqlite.execute({ sql, args });\n if (!results.rows || results.rows.length === 0) {\n let searchCriteria = `from Josh to ${to}`;\n if (body_contains) searchCriteria += ` with body containing \"${body_contains}\"`;\n if (subject_contains) searchCriteria += ` with subject containing \"${subject_contains}\"`;\n return {\n content: [{ type: \"text\", text: `No emails found ${searchCriteria}` }]\n };\n }\n const emails = results.rows.map((row: any) => ({\n subject: row[1],\n body: row[2],\n reply_to: row[5],\n sent_at: row[6]\n }));\n let searchCriteria = '';\n if (body_contains) searchCriteria += ` with body containing \"${body_contains}\"`;\n if (subject_contains) searchCriteria += ` with subject containing \"${subject_contains}\"`;\n let responseText = `Found ${emails.length} email${emails.length === 1 ? '' : 's'} from Josh to ${to}${searchCriteria}:\\n\\n`;\n emails.forEach((email, index) => {\n responseText += `[${new Date(email.sent_at).toLocaleString()}]\\n`;\n responseText += `Subject: ${email.subject}\\n`;\n if (email.reply_to) responseText += `Reply-To: ${email.reply_to}\\n`;\n responseText += `\\n${email.body}\\n`;\n if (index < emails.length - 1) responseText += '\\n---\\n\\n';\n });\n return {\n content: [{ type: \"text\", text: responseText }]\n };\n } catch (error) {\n return {\n content: [{ type: \"text\", text: `Error searching emails: ${error.message}` }]\n };\n }\n }\n );\n\n return server;\n } catch (error) {\n console.error(\"Error setting up MCP server:\", error);\n throw error;\n }\n}\n\n// Initialize database on startup\nawait initializeDatabase();\n\nconst mcpServer = await setupMcpServer();\n\nexport default app.fetch;\n","label",[131],"8e7ff8c0-6fb8-11f0-9bb5-0224a6c84d84",["D",1754149890377],4,"joshbeckman-personal-mcp",[28],"69379ef8-62b9-11f0-8eef-0224a6c84d84","README.md","69379f98-62b9-11f0-8eef-0224a6c84d84",["D",1752720892215],"# Password-Protected Key/Value Store\n\nA simple web application that provides a password-protected interface for managing key/value pairs with both web UI and JSON API access.\n\n## Features\n\n- **Password-protected web interface** for viewing current values\n- **Secure form** for updating values with separate write password\n- **JSON API** with Bearer token authentication\n- **Persistent storage** using Val Town's blob storage\n- **Responsive design** with TailwindCSS\n\n## Environment Variables\n\nSet these environment variables in your Val Town settings:\n\n- `READ_PASSWORD` - Password required to view the web interface and access the JSON API (default: \"read123\")\n- `WRITE_PASSWORD` - Password required to update values via the form (default: \"write123\")\n\n## Usage\n\n### Web Interface\n\n1. Visit the main URL\n2. Enter the `READ_PASSWORD` to access the interface\n3. View current values for `age` and `status` in the table\n4. Use the form to update values by providing new values and the `WRITE_PASSWORD`\n\n### JSON API\n\nAccess the values programmatically:\n\n```bash\ncurl -H \"Authorization: Bearer YOUR_READ_PASSWORD\" https://your-val-url.web.val.run/api/values\n```\n\nResponse format:\n```json\n{\n \"age\": \"25\",\n \"status\": \"active\"\n}\n```\n\n## API Endpoints\n\n- `GET /` - Main web interface (requires `password` query parameter)\n- `POST /update` - Update values via form submission (requires write password)\n- `GET /api/values` - JSON API endpoint (requires Bearer token authentication)\n\n## Default Values\n\nThe application initializes with:\n- `age`: \"25\"\n- `status`: \"active\"\n\n## Security\n\n- Read access requires password authentication\n- Write access requires separate password authentication\n- API access uses Bearer token authentication\n- All passwords are checked server-side\n- No sensitive data is exposed in client-side code",[147],"10b80430-62bd-11f0-b8d3-0224a6c84d84",".claude","10b80534-62bd-11f0-b8d3-0224a6c84d84",5,["D",1752722461725],"directory",[153],"pulls","branches",1,"forks","envVars",{"_167":169,"_170":62},"connections",{"_167":62,"_168":62},"count","unfilledCount",9,"emptyCount",{"_43":152,"_32":153,"_30":154,"_132":-5,"_41":42,"_40":155,"_134":58,"_38":194,"_13":62,"_33":157,"_35":-5,"_24":25,"_139":-5,"_177":195,"_27":196},{"_43":186,"_32":187,"_30":188,"_132":154,"_41":42,"_40":189,"_134":58,"_38":190,"_13":143,"_33":20,"_35":191,"_24":25,"_139":-5,"_177":192,"_27":193},{"_43":146,"_32":147,"_30":148,"_132":-5,"_41":42,"_40":143,"_134":58,"_38":183,"_13":62,"_33":20,"_35":150,"_24":25,"_139":-5,"_177":184,"_27":185},{"_43":141,"_32":28,"_30":31,"_132":-5,"_41":42,"_40":14,"_134":25,"_38":180,"_13":143,"_33":34,"_35":37,"_24":25,"_139":144,"_177":181,"_27":182},{"_43":130,"_32":131,"_30":56,"_132":-5,"_41":42,"_40":133,"_134":25,"_38":176,"_13":136,"_33":137,"_35":138,"_24":25,"_139":-5,"_177":178,"_27":179},["D",1754148744854],"children",[],[131],["D",1754149890377],[],[28],["D",1752720892215],[],[147],"d1b2a674-6388-11f0-9c87-0224a6c84d84","settings.local.json","10c3c090-62bd-11f0-8268-0224a6c84d84",75,["D",1752809973309],"{\n \"permissions\": {\n \"allow\": [\n \"Bash(/usr/bin/osascript:*)\",\n \"mcp__josh-beckman-status__get_current_time_of_day\",\n \"mcp__josh-beckman-status__get_status\",\n \"mcp__josh-beckman-status__email_josh\",\n \"mcp__josh-beckman-status__compare_time_relative\"\n ],\n \"deny\": []\n }\n}",[],[153,187],["D",1752722461725],[172],[153],["D",1752720187124],{"_96":95,"_103":99},{"_96":95,"_97":-5,"_98":99,"_18":54,"_100":101,"_102":25},{"_13":85,"_32":86,"_43":42,"_87":44,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":45,"_94":95},"ctx",{"_78":-5,"_123":234,"_235":236,"_237":238,"_239":25,"_240":25,"_241":25,"_242":58,"_243":-5,"_244":-7,"_245":-7,"_246":62,"_247":25,"_248":25,"_249":-5,"_250":25,"_251":25,"_252":25,"_253":-5},"ENV",{"_205":206,"_207":208,"_209":86,"_210":211,"_212":213,"_214":215,"_216":217,"_218":219,"_220":221,"_222":223,"_224":225,"_226":227,"_228":229,"_230":231,"_232":233},"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 · v104