[{"_1":2,"_172":-5,"_173":-5},"loaderData",{"_3":4,"_91":92},"root",{"_5":6,"_34":35,"_64":65},"ctx",{"_7":8,"_23":-5,"_24":25,"_26":27,"_28":20,"_29":20,"_30":20,"_31":32,"_33":20},"auth",{"_9":-5,"_10":-5,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":20,"_21":22},"sessionClaims","sessionId","sessionStatus","userId","actor","orgId","orgRole","orgSlug","orgPermissions","factorVerificationAge","isAuthenticated",false,"tokenType","session_token","user","preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","notificationCount",0,"flagDenols","ENV",{"_36":37,"_38":39,"_40":41,"_42":43,"_44":45,"_46":47,"_48":49,"_50":51,"_52":53,"_54":55,"_56":57,"_58":59,"_60":61,"_62":63},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","VAL_RUNTIME_NAME","prod","RENDER_GIT_COMMIT","ff0419d68e57d8cc3e37e5d3da688157c5dd37c6","RENDER_GIT_BRANCH","main","CLERK_PUBLISHABLE_KEY","pk_live_Y2xlcmsudmFsLnRvd24k","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","API_URL","https://api.val.town","clerkState",{"_66":67},"__internal_clerk_state",{"_68":69,"_70":45,"_71":72,"_73":72,"_74":20,"_75":72,"_76":72,"_77":72,"_78":72,"_79":80,"_89":20,"_90":20},"__clerk_ssr_state",{"_21":22,"_9":-5,"_10":-5,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":20},"__publishableKey","__proxyUrl","","__domain","__isSatellite","__signInUrl","__signUpUrl","__afterSignInUrl","__afterSignUpUrl","__clerk_debug",{"_81":20,"_19":20,"_82":72,"_83":84,"_85":72,"_86":45,"_87":20,"_88":72},"isSignedIn","proxyUrl","reason","session-token-and-uat-missing","message","publishableKey","isSatellite","domain","__telemetryDisabled","__telemetryDebug","routes/embed.x.$handle.$name.$",{"_93":94,"_95":96,"_97":98,"_99":100,"_150":151,"_169":170,"_171":-5},"handle","AIWB","name","mcp-server","path","main.ts","project",{"_101":102,"_95":96,"_103":104,"_105":-5,"_106":20,"_107":108,"_109":-5,"_110":-5,"_12":111,"_112":-5,"_113":20,"_114":-5,"_115":32,"_14":116,"_117":118,"_119":118,"_120":121,"_122":121,"_123":121,"_124":118,"_125":118,"_23":126,"_129":130,"_132":133,"_149":20},"id","7befff66-41a5-11f0-9673-76b3cceeab13","createdAt",["D",1749083945291],"deletedAt","legacyEnvVars","privacy","public","description","imageUrl","910c5de7-d7ef-46a2-9233-a36b504c0356","pinnedFileId","pinPreview","screenshotVersion","likeCount","3d0667b8-98c5-4e4b-9dab-f0c5e3bd2418","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm",{"_93":94,"_127":128},"profileImageUrl","https://img.clerk.com/eyJ0eXBlIjoicHJveHkiLCJzcmMiOiJodHRwczovL2ltYWdlcy5jbGVyay5kZXYvb2F1dGhfZ2l0aHViL2ltZ18ycU91M051U0JoMFZtclVEaFY2MDNCUmlFbTYifQ","org",{"_93":94,"_131":128},"avatar","branch",{"_134":135,"_95":43,"_101":136,"_137":102,"_138":139,"_140":141,"_142":108,"_143":144,"_145":146,"_147":96,"_148":94},"version",2,"7bf25b1c-41a5-11f0-9673-76b3cceeab13","projectId","forkedBranchId","181779bc-37f3-11f0-89f3-9e149126039e","forkedBranchVersion",45,"forkedProjectPrivacy","forkedProjectId","18173c4a-37f3-11f0-89f3-9e149126039e","forkedProjectOrgId","b1ec36cc-9d04-4938-872f-34bf39599d6a","projectName","userHandle","isOwned","file",{"_101":152,"_95":98,"_153":154,"_155":-5,"_156":136,"_157":135,"_158":159,"_103":160,"_134":161,"_162":163,"_164":165,"_166":20,"_167":-5,"_97":168},"d0b05bb6-45fd-11f0-9b4b-76b3cceeab13","fileId","b2ca276e-a3d3-4b92-bb1e-22cf59c60fe6","parentId","branchId","branchVersion","latest",true,["D",1749561687860],1,"fileType","http","content","console.log(`${new Date().toISOString()} Interpreting`);\nimport { Hono, Context } from 'npm:hono';\nimport { SSETransport } from 'npm:hono-mcp-server-sse-transport';\nimport { toFetchResponse, toReqRes } from \"npm:fetch-to-node\";\nimport { z } from \"npm:zod\";\nimport lunr from \"https://cdn.skypack.dev/lunr\";\nimport { StreamableHTTPServerTransport } from \"npm:@modelcontextprotocol/sdk/server/streamableHttp.js\";\nimport { McpServer, ResourceTemplate } from \"npm:@modelcontextprotocol/sdk/server/mcp.js\";\n// import { AuthInfo } from \"npm:@modelcontextprotocol/sdk/server/auth/types.js\";\nconsole.log(`${new Date().toISOString()} Loaded libraries`);\n\nconst SITE_URL = \"https://www.joshbeckman.org\";\nlunr.tokenizer.separator = /[\\s/]+/;\n\ntype Post = {\n author_id: string;\n book: number | string;\n content: string;\n date: string;\n doc: string;\n image: string;\n tags: string;\n title: string;\n type: string;\n url: string;\n backlinks: Array;\n sequences: Array;\n};\ntype Tag = {\n name: string;\n url: string;\n};\n\nfunction postFilter(post: Post) {\n return post.type == \"post\" || post.type == \"page\";\n}\n\nfunction buildTagsIndex(tags: Array) {\n return lunr(function() {\n this.ref(\"id\");\n this.field(\"name\");\n this.field(\"url\");\n this.metadataWhitelist = [\"position\"];\n\n for (var i = 0; i < tags.length; i++) {\n this.add({\n id: i,\n name: tags[i].name,\n url: tags[i].url,\n });\n }\n });\n}\nfunction search(input: string, index: lunr.Index, searchData: Record) {\n let results = index.search(input);\n\n if ((results.length == 0) && (input.length > 2)) {\n let tokens = lunr.tokenizer(input).filter(function(token, i) {\n return token.str.length < 20;\n });\n\n if (tokens.length > 0) {\n results = index.query(function(query) {\n query.term(tokens, {\n editDistance: Math.round(Math.sqrt(input.length / 2 - 1)),\n });\n });\n }\n }\n return results.map((result) => {\n const item = searchData[result.ref];\n if (!item) {\n return null; // Skip if item not found\n }\n return {\n title: item.title,\n content: item.content,\n type: item.type,\n url: SITE_URL + item.url,\n book: item.book,\n author_id: item.author_id,\n tags: item.tags,\n sequences: item.sequences,\n date: item.date,\n image: item.image,\n backlinks: item.backlinks,\n category: extractPostCategory(item),\n score: result.score,\n match: result.matchData.metadata,\n };\n }).filter((item) => item !== null); // Filter out null items\n}\n\nfunction searchTags(input: string, index: lunr.Index, tags: Array) {\n let results = index.search(input);\n\n if ((results.length == 0) && (input.length > 2)) {\n let tokens = lunr.tokenizer(input).filter(function(token, i) {\n return token.str.length < 20;\n });\n\n if (tokens.length > 0) {\n results = index.query(function(query) {\n query.term(tokens, {\n editDistance: Math.round(Math.sqrt(input.length / 2 - 1)),\n });\n });\n }\n }\n return results.map((result) => {\n const item = tags[parseInt(result.ref)];\n return {\n name: item.name,\n url: SITE_URL + item.url,\n score: result.score,\n match: result.matchData.metadata,\n };\n });\n}\nfunction formatPage(page: Post) {\n return [\n `# [${page.title}](${page.url})`,\n \"\",\n page.content,\n \"\",\n \"Metadata:\",\n `- Date: ${page.date}`,\n `- Tags: ${(page.tags || \"\").split(\" \").join(\", \")}`,\n `- Author: ${page.author_id}`,\n `- Category: ${page.category}`,\n (page.backlinks?.length > 0 ? `- Backlinks: ${page.backlinks.join(\", \")}` : null),\n (page.sequences?.length > 0 ? `- Sequences: ${page.sequences.map(seq => `[Sequence ${seq.id} on ${seq.topic}](${SITE_URL}/sequences#${seq.id})`).join(\", \")}` : null),\n (page.book ? `- Book: ${page.book}` : null),\n (page.image ? `- Image: ${page.image}` : null),\n (page.score ? `- Relevancy Score: ${page.score.toFixed(3)}` : null),\n ].filter((a) => a !== null).join(\"\\n\");\n}\n\nfunction extractPostCategory(post: Post) {\n if (post.type == \"page\") {\n return \"page\";\n }\n if (post.type == \"tag\") {\n return \"tag\";\n }\n if (post.url.includes(\"/notes/\")) {\n return \"notes\";\n } else if (post.url.includes(\"/exercise/\")) {\n return \"exercise\";\n } else if (post.url.includes(\"/replies/\")) {\n return \"replies\";\n } else {\n return \"blog\";\n }\n};\n\n// Cache for the MCP server instance\nlet mcpServerInstance: McpServer | null = null;\n\n/**\n * Sets up the MCP server with resources and tools based on the content on joshbeckman.org\n * Uses a cached instance if available\n */\nasync function setupMcpServer(): Promise {\n // Return cached instance if available\n if (mcpServerInstance) {\n return mcpServerInstance;\n }\n\n console.log(`${new Date().toISOString()} Registering MCP server tools`);\n // Create a new MCP server\n const server = new McpServer({\n name: \"joshbeckman.org Content\",\n version: \"1.1.0\",\n description: \"MCP server that provides access to the posts and data on the website joshbeckman.org. It includes tools for searching and reading posts, getting proverbs, and more. Use it to access the published work, thoughts, and data of Josh Beckman.\",\n },\n { capabilities: { logging: {} } });\n\n try {\n server.tool(\n \"get_proverbs\",\n \"Retrieve Josh's favorite proverbs\",\n { limit: z.number().optional() },\n async ({ limit }) => {\n console.log(`${new Date().toISOString()} Fetching proverbs data`);\n const proverbs = await fetch(\"https://www.joshbeckman.org/assets/js/proverbs.json\").then((res) => res.json());\n const results = proverbs\n .sort(() => Math.random() - 0.5)\n .slice(0, limit || 100);\n console.log(`${new Date().toISOString()} Proverbs data fetched`);\n const data = results.join(\"\\n\");\n return {\n content: [{ type: \"text\", text: data }]\n };\n }\n );\n server.tool(\n \"get_sequences\",\n \"Retrieve post sequences from the site. Sequences are groups of related posts that link, one to the next, forming a chain of thought on a tag.\",\n { limit: z.number().optional(), tag: z.string() },\n async ({ limit, tag }) => {\n console.log(`${new Date().toISOString()} Fetching sequences data for tag: ${tag}`);\n const sequences = await fetch(\"https://www.joshbeckman.org/assets/js/sequences.json\").then((res) => res.json());\n const results = sequences\n .filter((seq: any) => seq.topic == tag)\n .slice(0, limit || 100);\n console.log(`${new Date().toISOString()} Sequences data fetched`);\n if (results.length == 0) {\n return {\n content: [{ type: \"text\", text: `No sequences found for tag \"${tag}\".` }]\n };\n }\n const data = results.map((seq: any) => {\n return `## [Sequence on ${seq.topic}](${seq.id})\\n\\n${seq.posts.map((post: any) => `[${post.title}](${SITE_URL}${post.url})`).join(\"\\n\")}`;\n }).join(\"\\n\\n---\\n\\n\");\n return {\n content: [{ type: \"text\", text: data }]\n };\n }\n );\n server.tool(\n \"get_sequence\",\n \"Retrieve a specific post sequence by its ID. Sequences are groups of related posts that link, one to the next, forming a chain of thought on a tag.\",\n { id: z.string() },\n async ({ id }) => {\n console.log(`${new Date().toISOString()} Fetching sequence data for ID: ${id}`);\n const sequences = await fetch(\"https://www.joshbeckman.org/assets/js/sequences.json\").then((res) => res.json());\n const sequence = sequences.find((seq: any) => seq.id == id);\n console.log(`${new Date().toISOString()} Sequence data fetched`);\n if (!sequence) {\n return {\n content: [{ type: \"text\", text: `Sequence with ID \"${id}\" not found.` }]\n };\n }\n const data = `## [Sequence on ${sequence.topic}](${sequence.id})\\n\\n${sequence.posts.map((post: any) => `[${post.title}](${SITE_URL}${post.url})`).join(\"\\n\")}`;\n return {\n content: [{ type: \"text\", text: data }]\n };\n }\n );\n server.tool(\n \"search_tags\",\n \"Search for tags used on the site to group posts\",\n { query: z.string(), limit: z.number().optional() },\n async ({ query, limit }) => {\n console.log(`${new Date().toISOString()} Fetching tags data for search`);\n const tags = await fetch(\"https://www.joshbeckman.org/assets/js/tags.json\").then((res) => res.json());\n const tagsIndex = buildTagsIndex(tags);\n console.log(`${new Date().toISOString()} Tags search index built`);\n const results = searchTags(query, tagsIndex, tags);\n console.log(`${new Date().toISOString()} Tags search completed`);\n if (results.length == 0) {\n return {\n content: [{ type: \"text\", text: `No tags found matching \"${query}\".` }]\n };\n }\n const data = results\n .slice(0, limit || 10)\n .map((result) => {\n return result.name;\n }).join(\"\\n\");\n return {\n content: [{ type: \"text\", text: data }]\n };\n }\n );\n server.tool(\n \"get_tag_urls\",\n \"Get the URLs of provided tags\",\n { tags: z.array(z.string()) },\n async () => {\n console.log(`${new Date().toISOString()} Fetching tags data`);\n const sourceTags = await fetch(\"https://www.joshbeckman.org/assets/js/tags.json\")\n .then((res) => res.json());\n console.log(`${new Date().toISOString()} Tags data fetched`);\n const data = sourceTags.filter((tag) => tags.includes(tag.name)).map((tag) => {\n return `[${tag.name}](${SITE_URL}${tag.url})`;\n }).join(\"\\n\");\n return {\n content: [{ type: \"text\", text: data }]\n };\n }\n );\n server.tool(\n \"get_tags\",\n \"Get a list of all tags used on the site\",\n {},\n async () => {\n console.log(`${new Date().toISOString()} Fetching tags data`);\n const tags = await fetch(\"https://www.joshbeckman.org/assets/js/tags.json\")\n .then((res) => res.json());\n const data = tags.sort((a, b) => a.name.localeCompare(b.name)).map((tag) => {\n return tag.name;\n }).join(\"\\n\");\n console.log(`${new Date().toISOString()} Tags data fetched`);\n return {\n content: [{ type: \"text\", text: data }]\n };\n }\n );\n server.tool(\n \"get_post\",\n \"Get the full content and metadata of a specific post\",\n { url: z.string() },\n async ({ url }) => {\n console.log(`${new Date().toISOString()} Fetching post data for URL: ${url}`);\n const searchData = await fetch(\"https://www.joshbeckman.org/assets/js/SearchData.json\").then((res) => res.json());\n const db: Array = Object.values(searchData).filter(postFilter).map((post) => {\n post.author_id = post.author_id || \"joshbeckman\";\n post.category = extractPostCategory(post);\n return post;\n });\n const post = db.find((post) => post.url == url || `${SITE_URL}${post.url}` == url);\n console.log(`${new Date().toISOString()} Post data fetched`);\n if (!post) {\n return {\n content: [{ type: \"text\", text: `Post ${url} not found.` }]\n };\n }\n return {\n content: [{ type: \"text\", text: formatPage(post) }]\n };\n }\n );\n server.tool(\n \"search_posts\",\n \"Search for posts on the site, filtering by various metadata and content\",\n {\n query: z.string().optional(), \n limit: z.number().optional(),\n tag: z.string().optional(),\n startDate: z.string().optional(),\n endDate: z.string().optional(),\n author: z.string().optional(),\n book: z.string().optional(),\n category: z.enum([\"blog\", \"notes\", \"exercise\", \"replies\", \"page\"]).optional()\n },\n async ({ query, limit, tag, startDate, endDate, author, book, category }) => {\n console.log(`${new Date().toISOString()} loading search data`);\n const [searchData, indexCache] = await Promise.all([\n fetch(\"https://www.joshbeckman.org/assets/js/SearchData.json\").then((res) => res.json()),\n fetch(\"https://www.joshbeckman.org/assets/js/lunr-index.json\").then((res) => res.json()),\n ]);\n console.log(`${new Date().toISOString()} search data loaded`);\n const db: Array = Object.values(searchData).filter(postFilter).map((post) => {\n post.author_id = post.author_id || \"joshbeckman\";\n post.category = extractPostCategory(post);\n return post;\n });\n let filteredPosts = db;\n if (query) {\n console.log(`${new Date().toISOString()} building index for search query`);\n const searchIndex = lunr.Index.load(indexCache);\n console.log(`${new Date().toISOString()} search index built`);\n filteredPosts = search(query, searchIndex, filteredPosts.reduce((acc, post) => {\n acc[post.url] = post;\n return acc;\n }, {} as Record)).filter(postFilter).map((post) => {\n post.author_id = post.author_id || \"joshbeckman\";\n post.category = extractPostCategory(post);\n return post;\n });\n console.log(`${new Date().toISOString()} search query completed`);\n }\n if (tag) {\n filteredPosts = filteredPosts.filter((post) => post.tags.includes(tag));\n }\n if (startDate) {\n filteredPosts = filteredPosts.filter((post) => post.date >= startDate);\n }\n if (endDate) {\n filteredPosts = filteredPosts.filter((post) => post.date <= endDate);\n }\n if (author) {\n filteredPosts = filteredPosts.filter((post) => post.author_id === author);\n }\n if (book) {\n filteredPosts = filteredPosts.filter((post) => post.book?.toString() === book);\n }\n if (category) {\n filteredPosts = filteredPosts.filter((post) => post.category === category);\n }\n let results = filteredPosts.map((post) => {\n post.author_id = post.author_id || \"joshbeckman\";\n post.url = post.url.startsWith(\"http\") ? post.url : SITE_URL + post.url;\n post.score = post.score || 1; // Default score to 1 if not present\n return post;\n });\n const data = results\n .slice(0, limit || 5)\n .map((result) => {\n return formatPage(result);\n }).join(\"\\n\\n---\\n\\n\");\n return {\n content: [{ type: \"text\", text: data }]\n };\n }\n );\n // Cache the server instance\n mcpServerInstance = server;\n console.log(`${new Date().toISOString()} MCP server tools registered`);\n\n return server;\n } catch (error) {\n console.error(\"Error setting up MCP server:\", error);\n throw error;\n }\n}\n\nconst server = await setupMcpServer();\nconst app = new Hono();\n\napp.post(\"/mcp\", async (c) => {\n const { req, res } = toReqRes(c.req.raw);\n\n // Disabling auth for now\n // if (!req.headers.authorization) {\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 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 // Disabling auth for now\n // req.auth = { token: req.headers[\"authorization\"]?.split(\" \")[1] } as AuthInfo;\n\n console.log(`${new Date().toISOString()} Received MCP request`);\n await server.connect(transport);\n await transport.handleRequest(req, res, await c.req.json());\n console.log(`${new Date().toISOString()} MCP request handled`);\n\n res.on(\"close\", () => {\n console.log(`${new Date().toISOString()} Request closed`);\n transport.close();\n server.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\n/**\n * Val.town handler function for HTTP requests\n * This will be exposed as a Val.town HTTP endpoint\n */\nexport default app.fetch;\n","deleted","label",[98],"permalink","https://www.val.town/x/AIWB/mcp-server/code/main.ts","extension","actionData","errors"]