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 if (!replyTo) {\n replyTo = INBOUND_EMAIL_ADDRESS;;\n }\n const emailOptions: any = {\n subject: subject,\n text: emailBody,\n 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]\n });\n return {\n content: [{ type: \"text\", text: `Email \"${subject}\" sent!\\n\\nFrom: ${from}${replyTo ? `\\nReply-To: ${replyTo}` : ''}` }]\n };\n }\n );\n server.registerTool(\n \"send_push_notification_to_josh\",\n {\n title: \"Push Notification to Josh Beckman\",\n description: \"Send a push notification to Josh Beckman. The 'title' is the notification title, and the 'body' is the notification content. The 'from' field should uniquely identify the sender (either an agent's handle or a human user's username/handle).\",\n inputSchema: {\n title: z.string().max(50, \"Title should be 50 characters or less\"),\n body: z.string().max(150, \"Notification messages should be 150 characters or less\"),\n from: usernameSchema,\n url: z.string().url(\"Must be a valid URL\").optional(),\n },\n },\n async ({ title, body, from, url }) => {\n const message = `${body}\\nFrom: ${from}`;\n const pushover = new Push({\n token: Deno.env.get(\"PUSHOVER_API_TOKEN\"),\n user: Deno.env.get(\"PUSHOVER_USER_KEY\"),\n });\n let params: any = {\n title: title,\n message: message,\n };\n if (url) {\n params.url = url;\n params.url_title = \"View Details\";\n }\n pushover.send(params, (error, result) => {\n if (error) {\n console.error(\"Error sending push notification:\", error);\n throw new Error(\"Failed to send push notification\");\n }\n });\n return {\n content: [{ type: \"text\", text: `Push notification sent!\\n\\nTitle: ${title}\\nFrom: ${from}` }]\n };\n }\n );\n server.registerTool(\n \"read_josh_email_responses\",\n {\n title: \"Read Josh's Email Responses\",\n description: \"Read emails sent from Josh to you. 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 console.log(`Searching emails with SQL: ${sql}, args: ${JSON.stringify(args)}`);\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 to: row[4],\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).toISOString()}]\\n`;\n responseText += `To: ${email.to}\\n`;\n responseText += `Subject: ${email.subject}\\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",[123],"b02f4978-6fbb-11f0-aa3a-0224a6c84d84","email.ts","b2731a10-6fb7-11f0-9f74-0224a6c84d84",115,["D",1754151235372],8,"email","import { sqlite } from \"https://esm.town/v/std/sqlite\";\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 // e.from is going to be something like \"Josh Beckman \"\n // we want to extract the email address from it\n let fromSender = e.from.match(/<([^>]+)>/);\n if (!fromSender) {\n fromSender = e.from.match(/([^<\\s]+@[^>\\s]+)/);\n }\n if (!fromSender) {\n fromSender = [null, e.from];\n }\n if (!KNOWN_SENDERS.includes(fromSender[1])) {\n console.warn(`Email from unknown sender: ${e.from}`);\n console.log(e);\n return;\n }\n const body = e.text || e.html || '';\n // Match \"To: username\" pattern, handling both \\n and \\r newlines\n // Username must start and end with alphanumeric, can contain letters, numbers, dots, underscores, hyphens\n const toMatch = body.match(/To:\\s*([a-zA-Z0-9][a-zA-Z0-9._-]*[a-zA-Z0-9])(?:[\\r\\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, fromSender[1], toMatch ? toMatch[1] : '', e.replyTo || e.from],\n });\n}\n","joshbeckman-personal-mcp",[136],"69379ef8-62b9-11f0-8eef-0224a6c84d84","README.md","69379f98-62b9-11f0-8eef-0224a6c84d84",4,["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",[146],"10b80430-62bd-11f0-b8d3-0224a6c84d84",".claude","10b80534-62bd-11f0-b8d3-0224a6c84d84",5,["D",1752722461725],[153],"pulls","branches",1,"forks","envVars",{"_166":168,"_169":26},"connections",{"_166":26,"_167":26},"count","unfilledCount",9,"emptyCount",{"_40":152,"_13":153,"_32":154,"_124":-5,"_125":82,"_126":155,"_127":24,"_42":193,"_80":26,"_35":36,"_131":-5,"_37":30,"_133":-5,"_176":194,"_17":195},{"_40":185,"_13":186,"_32":187,"_124":154,"_125":82,"_126":188,"_127":24,"_42":189,"_80":148,"_35":21,"_131":190,"_37":30,"_133":-5,"_176":191,"_17":192},{"_40":145,"_13":146,"_32":147,"_124":-5,"_125":82,"_126":148,"_127":24,"_42":182,"_80":26,"_35":21,"_131":150,"_37":30,"_133":-5,"_176":183,"_17":184},{"_40":135,"_13":136,"_32":137,"_124":-5,"_125":82,"_126":138,"_127":24,"_42":179,"_80":140,"_35":141,"_131":142,"_37":30,"_133":143,"_176":180,"_17":181},{"_40":122,"_13":123,"_32":53,"_124":-5,"_125":82,"_126":81,"_127":24,"_42":175,"_80":129,"_35":130,"_131":132,"_37":30,"_133":-5,"_176":177,"_17":178},["D",1754274929379],"children",[],[123],["D",1754151235372],[],[136],["D",1752720892215],[],[146],"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,186],["D",1752722461725],[171],[153],["D",1752720187124],{"_11":12,"_97":93},{"_11":12,"_91":-5,"_92":93,"_31":51,"_94":95,"_96":30},{"_80":81,"_13":16,"_40":82,"_83":41,"_84":-5,"_85":-5,"_86":-5,"_87":-5,"_88":-5,"_89":14,"_90":12},"ctx",{"_73":-5,"_115":233,"_234":235,"_236":237,"_238":30,"_239":30,"_240":30,"_241":24,"_242":-5,"_243":-7,"_244":-7,"_245":26,"_246":30,"_247":30,"_248":-5,"_249":30,"_250":30,"_251":30,"_252":-5},"ENV",{"_204":205,"_206":207,"_208":16,"_209":210,"_211":212,"_213":214,"_215":216,"_217":218,"_219":220,"_221":222,"_223":224,"_225":226,"_227":228,"_229":230,"_231":232},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","811aa22498c9b0b5a47e8d778de579cdb990f332","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"]

History · b7