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","deleted","label",[98],"permalink","https://www.val.town/x/joshbeckman/personal-mcp/code/main.ts","extension","actionData","errors"]