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 ? `Last updated: ${values.updated_at}` : \"\";\n return {\n content: [{ type: \"text\", text: `${values.status || \"No status available\"}\\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 const updatedAt = values.updated_at ? `Last updated: ${values.updated_at}` : \"\";\n return {\n content: [{ type: \"text\", text: `Current time for Josh (in ${timezone}) is ${timeString} and it's ${partOfDay}.\\nThe season is ${season}.\\n${updatedAt}` }]\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.iso.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 \"email_josh\",\n {\n title: \"Email Josh Beckman\",\n description: \"Send an email to Josh Beckman.\",\n inputSchema: {\n properties: {\n subject: z.string(),\n body: z.string(),\n replyTo: z.string().email(\"Must be a valid email address\"),\n },\n required: [\"subject\", \"body\", \"replyTo\"],\n },\n },\n async ({ subject, body, replyTo }) => {\n await email({\n subject: subject,\n text: body,\n });\n return {\n content: [{ type: \"text\", text: `Email \"${subject}\" sent successfully!` }]\n };\n }\n );\n server.registerTool(\"add\",\n {\n title: \"Addition Tool\",\n description: \"Add two numbers\",\n inputSchema: { a: z.number(), b: z.number() }\n },\n async ({ a, b }) => ({\n content: [{ type: \"text\", text: String(a + b) }]\n })\n);\n\n return server;\n } catch (error) {\n console.error(\"Error setting up MCP server:\", error);\n throw error;\n }\n}\n\nconst mcpServer = await setupMcpServer();\n\nexport default app.fetch;\n",[],[191],"files",[150,168,180,189],"counts",{"_202":32,"_203":204,"_205":32,"_206":207},"pulls","branches",1,"forks","envVars",{"_208":209,"_210":32},"count",9,"emptyCount","contents",[213],{"_104":169,"_95":170,"_152":171,"_154":153,"_155":138,"_156":172,"_158":22,"_106":214,"_100":174,"_161":175,"_163":176,"_164":22,"_165":-5,"_98":215},["D",1752804199772],[99,170],{"_104":151,"_95":99,"_152":153,"_154":-5,"_155":138,"_156":157,"_158":159,"_106":217,"_100":32,"_161":162,"_163":-5,"_164":22,"_165":-5,"_98":218},["D",1752722461725],[99],"upstreamProject","upstreamBranch","emptyEnvVars","isNew","flags",[],"routes/_app.x.$handle.$name.branch.$branch.version.$version.code.$",{"_93":94,"_95":96,"_97":43,"_100":101,"_98":99,"_102":227,"_148":232,"_198":245,"_175":246,"_211":248,"_251":-5,"_252":-5,"_253":-5,"_254":-5,"_255":256},{"_104":105,"_95":96,"_106":228,"_108":-5,"_109":22,"_110":111,"_112":-5,"_113":-5,"_14":114,"_115":-5,"_116":22,"_117":-5,"_118":32,"_16":119,"_120":121,"_122":121,"_123":124,"_125":124,"_126":124,"_127":121,"_128":121,"_23":229,"_132":230,"_135":231,"_147":22},["D",1752720187124],{"_93":94,"_130":131},{"_93":94,"_134":131,"_14":114},{"_100":137,"_95":43,"_104":138,"_139":105,"_140":-5,"_141":-5,"_142":-5,"_143":-5,"_144":-5,"_145":96,"_146":94},[233,239,242],{"_104":151,"_95":99,"_152":153,"_154":-5,"_155":138,"_156":157,"_158":159,"_106":160,"_100":32,"_161":162,"_163":-5,"_164":22,"_165":-5,"_166":234,"_98":238},[235],{"_104":169,"_95":170,"_152":171,"_154":153,"_155":138,"_156":172,"_158":22,"_106":173,"_100":174,"_161":175,"_163":176,"_164":22,"_165":-5,"_166":236,"_98":237},[],[99,170],[99],{"_104":181,"_95":182,"_152":183,"_154":-5,"_155":138,"_156":184,"_158":159,"_106":185,"_100":32,"_161":175,"_163":186,"_164":22,"_165":-5,"_166":240,"_98":241},[],[182],{"_104":190,"_95":191,"_152":192,"_154":-5,"_155":138,"_156":101,"_158":22,"_106":193,"_100":172,"_161":194,"_163":195,"_164":22,"_165":-5,"_166":243,"_98":244},[],[191],[233,235,239,242],{"_104":151,"_95":99,"_152":153,"_154":-5,"_155":138,"_156":157,"_158":159,"_106":217,"_100":32,"_161":162,"_163":-5,"_164":22,"_165":-5,"_98":247},[99],[249],{"_104":169,"_95":170,"_152":171,"_154":153,"_155":138,"_156":172,"_158":22,"_106":214,"_100":174,"_161":175,"_163":176,"_164":22,"_165":-5,"_98":250},[99,170],"upstream","pull","ahead","behind","templates",[],"actionData","errors"]

joshbeckman

personal-mcp