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",[130],"b8b0cf30-6fb7-11f0-bb7e-0224a6c84d84",["D",1754149531643],1,"joshbeckman-personal-mcp",[28],"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],"directory",[153],"pulls","branches","forks","envVars",{"_166":168,"_169":62},"connections",{"_166":62,"_167":62},"count","unfilledCount",9,"emptyCount",{"_43":152,"_32":153,"_30":154,"_131":-5,"_41":42,"_40":155,"_133":58,"_38":193,"_13":62,"_34":157,"_36":-5,"_24":25,"_138":-5,"_176":194,"_27":195},{"_43":185,"_32":186,"_30":187,"_131":154,"_41":42,"_40":188,"_133":58,"_38":189,"_13":148,"_34":20,"_36":190,"_24":25,"_138":-5,"_176":191,"_27":192},{"_43":145,"_32":146,"_30":147,"_131":-5,"_41":42,"_40":148,"_133":58,"_38":182,"_13":62,"_34":20,"_36":150,"_24":25,"_138":-5,"_176":183,"_27":184},{"_43":140,"_32":28,"_30":31,"_131":-5,"_41":42,"_40":14,"_133":25,"_38":179,"_13":142,"_34":35,"_36":37,"_24":25,"_138":143,"_176":180,"_27":181},{"_43":129,"_32":130,"_30":56,"_131":-5,"_41":42,"_40":132,"_133":25,"_38":175,"_13":135,"_34":136,"_36":137,"_24":25,"_138":-5,"_176":177,"_27":178},["D",1754148744854],"children",[],[130],["D",1754149531643],[],[28],["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],{"_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,"_122":233,"_234":235,"_236":237,"_238":25,"_239":25,"_240":25,"_241":58,"_242":-5,"_243":-7,"_244":-7,"_245":62,"_246":25,"_247":25,"_248":-5,"_249":25,"_250":25,"_251":25,"_252":-5},"ENV",{"_204":205,"_206":207,"_208":86,"_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","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 · v101