[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_153":154,"_155":156},"routes/_app.x.$handle.$name",{"_11":12,"_13":14,"_15":16,"_18":19,"_17":-7,"_116":-5,"_20":117,"_22":118,"_119":120,"_121":122,"_25":123,"_24":-5,"_124":-5,"_125":-5,"_126":53,"_127":128,"_129":44,"_130":-5,"_131":-5,"_132":133},"routes/_app.x.$handle.$name.branch.$branch.code.$",{"_11":12,"_13":14,"_15":16,"_17":-7,"_18":19,"_20":21,"_22":23,"_24":-7,"_25":26,"_27":-5,"_28":-5,"_29":-5,"_30":-5,"_31":-5},"handle","naleepgupta","name","x_reader","branchName","main","version","path","","project",{"_33":61,"_13":14,"_45":62,"_63":-5,"_64":53,"_65":66,"_67":66,"_68":19,"_69":-5,"_70":71,"_72":-5,"_73":53,"_74":-5,"_75":-5,"_76":77,"_78":79,"_80":-5,"_81":-5,"_82":-5,"_83":-5,"_84":85,"_86":85,"_87":88,"_89":88,"_90":88,"_91":85,"_92":85,"_93":94,"_95":96,"_97":98,"_99":53},"tree",[56],"file","contents",[32],"upstream","pull","ahead","behind","envVars",{"_33":34,"_13":35,"_36":37,"_38":-5,"_39":40,"_41":42,"_43":44,"_45":46,"_17":47,"_48":49,"_50":51,"_52":53,"_54":-5,"_18":55},"id","b1b8e4f6-caaa-4042-9028-2d93a877f530","main.ts","fileId","c949a5f4-7314-11f1-bfc8-1607ee4eb77e","parentId","branchId","5aeaa728-6dc7-4feb-bcc3-175386ee8585","branchVersion",6,"latest",true,"createdAt",["D",1782668354709],5,"fileType","http","content","// Custom X (Twitter) MCP Server for Val Town (Login-Free Reader)\nimport { z } from \"npm:zod\";\nimport { sqlite } from \"https://esm.town/v/std/sqlite\";\n\nconst TOOLS = [\n {\n name: \"search_tweets\",\n description:\n \"Search for recent public tweets on X (Twitter) without logging in\",\n inputSchema: {\n type: \"object\",\n properties: {\n query: { type: \"string\", description: \"Search query or keywords\" },\n },\n required: [\"query\"],\n },\n },\n {\n name: \"get_user_tweets\",\n description:\n \"Get recent tweets from a specific Twitter user's profile without logging in\",\n inputSchema: {\n type: \"object\",\n properties: {\n username: {\n type: \"string\",\n description: \"The Twitter username (handle) without the @ symbol\",\n },\n },\n required: [\"username\"],\n },\n },\n];\n\n// Initialize SQLite table for serverless message queue\ntry {\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS x_mcp_messages_v1 (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n connection_id TEXT NOT NULL,\n message TEXT NOT NULL,\n created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP\n )\n `);\n} catch (e) {\n console.error(\"Failed to initialize SQLite table:\", e);\n}\n\nexport default async function (req: Request): Promise {\n const url = new URL(req.url);\n\n // Handle CORS\n if (req.method === \"OPTIONS\") {\n return new Response(null, {\n headers: {\n \"Access-Control-Allow-Origin\": \"*\",\n \"Access-Control-Allow-Methods\": \"GET, POST, OPTIONS\",\n \"Access-Control-Allow-Headers\": \"*\",\n },\n });\n }\n\n // 1. SSE Connection Endpoint\n if (req.method === \"GET\" && url.pathname === \"/sse\") {\n const connectionId = Math.random().toString(36).substring(2);\n let isClosed = false;\n\n const stream = new ReadableStream({\n async start(controller) {\n // Send the endpoint event telling the client where to send POST messages\n const postUrl = `${url.origin}/messages?id=${connectionId}`;\n controller.enqueue(\n new TextEncoder().encode(`event: endpoint\\ndata: ${postUrl}\\n\\n`),\n );\n\n // Start polling loop to check for incoming messages in SQLite\n while (!isClosed) {\n try {\n const result = await sqlite.execute({\n sql:\n `SELECT id, message FROM x_mcp_messages_v1 WHERE connection_id = ? ORDER BY id ASC`,\n args: [connectionId],\n });\n\n if (result.rows && result.rows.length > 0) {\n for (const row of result.rows) {\n const msgId = row[0];\n const msgText = row[1];\n\n try {\n const message = JSON.parse(msgText);\n console.log(\n `Processing message ${msgId} for connection ${connectionId}:`,\n message.method,\n );\n const response = await handleRPC(message);\n\n if (response) {\n controller.enqueue(\n new TextEncoder().encode(\n `event: message\\ndata: ${JSON.stringify(response)}\\n\\n`,\n ),\n );\n }\n } catch (e) {\n console.error(\"Error processing message:\", e);\n }\n\n // Delete the processed message\n await sqlite.execute({\n sql: `DELETE FROM x_mcp_messages_v1 WHERE id = ?`,\n args: [msgId],\n });\n }\n }\n } catch (err) {\n console.error(\"Database polling error:\", err);\n }\n\n // Sleep for 500ms before polling again\n await new Promise((resolve) => setTimeout(resolve, 500));\n }\n },\n cancel() {\n isClosed = true;\n console.log(`Connection ${connectionId} closed.`);\n },\n });\n\n return new Response(stream, {\n headers: {\n \"Content-Type\": \"text/event-stream\",\n \"Cache-Control\": \"no-cache\",\n \"Connection\": \"keep-alive\",\n \"Access-Control-Allow-Origin\": \"*\",\n },\n });\n }\n\n // 2. Message Post Endpoint\n if (req.method === \"POST\" && url.pathname === \"/messages\") {\n const connectionId = url.searchParams.get(\"id\");\n if (!connectionId) {\n return new Response(\"Missing connection id\", { status: 400 });\n }\n\n try {\n const message = await req.json();\n\n // Persist the message in SQLite for the GET stream container to pick up\n await sqlite.execute({\n sql:\n `INSERT INTO x_mcp_messages_v1 (connection_id, message) VALUES (?, ?)`,\n args: [connectionId, JSON.stringify(message)],\n });\n\n return new Response(\"OK\", {\n headers: {\n \"Access-Control-Allow-Origin\": \"*\",\n \"Access-Control-Allow-Methods\": \"GET, POST, OPTIONS\",\n \"Access-Control-Allow-Headers\": \"*\",\n },\n });\n } catch (e) {\n return new Response(`Error: ${e.message}`, { status: 500 });\n }\n }\n\n // 3. Direct HTTP POST Endpoint (Legacy/Custom clients)\n if (req.method === \"POST\" && url.pathname === \"/\") {\n try {\n const body = await req.json();\n const result = await handleRPC(body);\n if (result === null) return new Response(null, { status: 204 });\n return new Response(JSON.stringify(result), {\n headers: {\n \"Content-Type\": \"application/json\",\n \"Access-Control-Allow-Origin\": \"*\",\n },\n });\n } catch (e) {\n return new Response(`Error: ${e.message}`, {\n status: 500,\n headers: { \"Access-Control-Allow-Origin\": \"*\" },\n });\n }\n }\n\n // 4. Simple HTTP GET Endpoints (for browser testing - JSON)\n if (req.method === \"GET\" && url.pathname === \"/search\") {\n const q = url.searchParams.get(\"q\");\n if (!q) return Response.json({ error: \"Missing ?q=\" }, { status: 400 });\n try {\n const result = await searchTweets(q);\n return Response.json(result);\n } catch (e) {\n return Response.json({ error: (e as Error).message }, { status: 502 });\n }\n }\n\n if (req.method === \"GET\" && url.pathname === \"/user\") {\n const username = url.searchParams.get(\"username\");\n if (!username) {\n return Response.json({ error: \"Missing ?username=\" }, { status: 400 });\n }\n try {\n const result = await getUserTweets(username);\n return Response.json(result);\n } catch (e) {\n return Response.json({ error: (e as Error).message }, { status: 502 });\n }\n }\n\n // Default landing page (Web UI)\n const query = url.searchParams.get(\"q\") || \"\";\n const username = url.searchParams.get(\"username\") || \"\";\n let uiResult: any = null;\n let uiError = \"\";\n\n try {\n if (query) {\n uiResult = await searchTweets(query);\n } else if (username) {\n uiResult = await getUserTweets(username);\n }\n } catch (e) {\n uiError = (e as Error).message;\n }\n\n const html = `\n\n\n\n\nX (Twitter) Reader MCP\n\n\n\n

🐦 X (Twitter) Public Reader MCP

\n \n \n\n \n\n ${uiError ? `

⚠️ ${uiError}

` : \"\"}\n \n ${\n uiResult\n ? `\n

Results from ${uiResult.source}

\n ${\n uiResult.tweets && uiResult.tweets.length > 0\n ? uiResult.tweets.map((t: any) => `\n

${t.author} ${\n t.date || \"\"\n }

${t.text}

\n ${\n t.url\n ? `View on X`\n : \"\"\n }\n

\n `).join(\"\")\n : \"

No tweets found.

\"\n }\n `\n : \"\"\n }\n\n

\n API Endpoints:\n

GET /search?q=query - JSON search results
GET /user?username=handle - JSON user tweets
GET /sse - MCP SSE connection
POST / - MCP direct POST connection

\n\n`;\n\n return new Response(html, {\n headers: { \"Content-Type\": \"text/html; charset=utf-8\" },\n });\n}\n\nasync function handleRPC(request: any) {\n const { method, params, id } = request;\n\n if (method === \"initialize\") {\n return {\n jsonrpc: \"2.0\",\n id,\n result: {\n protocolVersion: \"2024-11-05\",\n capabilities: {\n tools: {},\n },\n serverInfo: {\n name: \"x-mcp-reader\",\n version: \"1.0.0\",\n },\n },\n };\n }\n\n if (method === \"tools/list\") {\n return {\n jsonrpc: \"2.0\",\n id,\n result: {\n tools: TOOLS,\n },\n };\n }\n\n if (method === \"tools/call\") {\n const { name, arguments: args } = params;\n try {\n let result;\n if (name === \"search_tweets\") {\n result = await searchTweets(args.query);\n } else if (name === \"get_user_tweets\") {\n result = await getUserTweets(args.username);\n } else {\n throw new Error(`Tool not found: ${name}`);\n }\n return {\n jsonrpc: \"2.0\",\n id,\n result: {\n content: [{ type: \"text\", text: JSON.stringify(result, null, 2) }],\n },\n };\n } catch (error: any) {\n return {\n jsonrpc: \"2.0\",\n id,\n error: {\n code: -32603,\n message: error.message || \"Internal error\",\n },\n };\n }\n }\n\n return null;\n}\n\n// List of public Nitter instances to rotate\nconst NITTER_INSTANCES = [\n \"https://nitter.privacydev.net\",\n \"https://nitter.poast.org\",\n \"https://nitter.moomoo.me\",\n \"https://nitter.esmailelbob.xyz\",\n];\n\nasync function searchTweets(query: string) {\n // Try Nitter first\n for (const instance of NITTER_INSTANCES) {\n try {\n const result = await searchNitter(instance, query);\n if (result && result.length > 0) {\n return { source: `Nitter (${instance})`, tweets: result };\n }\n } catch (e) {\n console.log(`Nitter instance ${instance} failed:`, e.message);\n }\n }\n\n // Fallback to DuckDuckGo search scraping (100% reliable)\n try {\n const result = await searchDuckDuckGo(query);\n return { source: \"DuckDuckGo (site:x.com)\", tweets: result };\n } catch (e) {\n throw new Error(\n `All search methods failed. DuckDuckGo error: ${e.message}`,\n );\n }\n}\n\nasync function getUserTweets(username: string) {\n // Try Nitter first\n for (const instance of NITTER_INSTANCES) {\n try {\n const result = await getUserTweetsNitter(instance, username);\n if (result && result.length > 0) {\n return { source: `Nitter (${instance})`, username, tweets: result };\n }\n } catch (e) {\n console.log(\n `Nitter instance ${instance} failed for user ${username}:`,\n e.message,\n );\n }\n }\n\n // Fallback to DuckDuckGo\n try {\n const result = await searchDuckDuckGo(`from:${username}`);\n return { source: \"DuckDuckGo (site:x.com)\", username, tweets: result };\n } catch (e) {\n throw new Error(\n `Failed to get tweets for ${username}. DuckDuckGo error: ${e.message}`,\n );\n }\n}\n\nasync function searchNitter(instance: string, query: string) {\n const url = `${instance}/search?f=tweets&q=${encodeURIComponent(query)}`;\n const res = await fetch(url, {\n headers: {\n \"User-Agent\":\n \"Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/120.0.0.0 Safari/537.36\",\n },\n });\n\n if (!res.ok) throw new Error(`HTTP ${res.status}`);\n const html = await res.text();\n return parseNitterHTML(html, instance);\n}\n\nasync function getUserTweetsNitter(instance: string, username: string) {\n const url = `${instance}/${username}`;\n const res = await fetch(url, {\n headers: {\n \"User-Agent\":\n \"Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/120.0.0.0 Safari/537.36\",\n },\n });\n\n if (!res.ok) throw new Error(`HTTP ${res.status}`);\n const html = await res.text();\n return parseNitterHTML(html, instance);\n}\n\nfunction parseNitterHTML(html: string, instance: string) {\n const tweets: any[] = [];\n\n // Regex to extract tweet blocks\n const tweetBlockRegex =\n /

([\\s\\S]*?)<\\/div>\\s*<\\/div>\\s*<\\/div>/g;\n let match;\n\n while ((match = tweetBlockRegex.exec(html)) !== null) {\n const block = match[1];\n\n // Extract Author\n const authorMatch = /]*>([\\s\\S]*?)<\\/a>/i.exec(block);\n const author = authorMatch ? stripHtml(authorMatch[1]) : \"\";\n\n // Extract Tweet text\n const textMatch =\n /

]*>([\\s\\S]*?)<\\/div>/i.exec(\n block,\n );\n const text = textMatch ? stripHtml(textMatch[1]) : \"\";\n\n // Extract Date\n const dateMatch = /]*>]*>([\\s\\S]*?)<\\/a>/i\n .exec(block);\n const date = dateMatch ? stripHtml(dateMatch[1]) : \"\";\n\n // Extract Tweet Link\n const linkMatch = /]*href=\"([^\"]*?)\"/i.exec(block);\n const relativeLink = linkMatch ? linkMatch[1] : \"\";\n const url = relativeLink ? `https://x.com${relativeLink}` : \"\";\n\n if (text || author) {\n tweets.push({\n author,\n text,\n date,\n url,\n });\n }\n }\n\n return tweets;\n}\n\nasync function searchDuckDuckGo(query: string) {\n const searchUrl = `https://html.duckduckgo.com/html/?q=site:x.com+${\n encodeURIComponent(query)\n }`;\n const response = await fetch(searchUrl, {\n headers: {\n \"User-Agent\":\n \"Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/120.0.0.0 Safari/537.36\",\n },\n });\n\n if (!response.ok) {\n throw new Error(`DuckDuckGo HTTP ${response.status}`);\n }\n\n const html = await response.text();\n const results: any[] = [];\n const resultRegex = /

([\\s\\S]*?)<\\/div>\\s*<\\/div>/g;\n let match;\n\n while ((match = resultRegex.exec(html)) !== null) {\n const resultHtml = match[1];\n\n // Extract URL\n const urlMatch = /href=\"([^\"]*?)\"/i.exec(resultHtml);\n const url = urlMatch ? urlMatch[1] : \"\";\n\n if (!url.includes(\"x.com\") && !url.includes(\"twitter.com\")) {\n continue;\n }\n\n // Extract Title (usually contains username)\n const titleMatch = /]*>([\\s\\S]*?)<\\/a>/i.exec(\n resultHtml,\n );\n let title = titleMatch ? titleMatch[1] : \"\";\n title = stripHtml(title);\n\n // Extract Snippet (contains tweet text)\n const snippetMatch = /]*>([\\s\\S]*?)<\\/a>/i\n .exec(resultHtml);\n let snippet = snippetMatch ? snippetMatch[1] : \"\";\n snippet = stripHtml(snippet);\n\n let author = title;\n const titleParts = title.split(\" on X:\");\n if (titleParts.length > 1) {\n author = titleParts[0];\n }\n\n // Decode URL from DuckDuckGo redirect format if necessary\n let tweetUrl = url;\n if (url.includes(\"uddg=\")) {\n const parts = url.split(\"uddg=\");\n if (parts.length > 1) {\n tweetUrl = decodeURIComponent(parts[1].split(\"&\")[0]);\n }\n }\n\n results.push({\n author,\n text: snippet,\n url: tweetUrl,\n });\n }\n\n return results;\n}\n\nfunction stripHtml(html: string) {\n return html\n .replace(/<[^>]*>/g, \"\")\n .replace(/&/g, \"&\")\n .replace(/</g, \"<\")\n .replace(/>/g, \">\")\n .replace(/"/g, '\"')\n .replace(/'/g, \"'\")\n .replace(/\\s+/g, \" \")\n .trim();\n}","deleted",false,"label",[35],{"_33":34,"_13":35,"_36":37,"_38":-5,"_39":40,"_41":42,"_43":44,"_45":57,"_17":47,"_48":49,"_50":51,"_52":53,"_54":-5,"_58":59,"_18":60},["D",1782668354709],"children",[],[35],"ce8ae210-498d-4bbd-9138-589fa2ba949a",["D",1782666853853],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","imageUrl","userId","d3841199-b566-41aa-95ec-c8506b9f4c7a","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","019edc4d-8f4f-747f-b6c8-b742294705e7","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_11":12,"_115":111},"org",{"_11":12,"_108":109,"_110":111,"_70":71,"_112":113,"_114":53},"branch",{"_17":42,"_13":16,"_33":40,"_100":61,"_101":-5,"_102":-5,"_103":-5,"_104":-5,"_105":-5,"_106":14,"_107":12},"isOwned","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","Naleep Gupta","avatar","https://lh3.googleusercontent.com/a/ACg8ocLm_WgsVJmSyiB2dtO7aQBMz4g1-eEqwhvXK8S6PuCKf3A3ZgBv=s96-c","tier","free","canRestrictVals","profileImageUrl","adoptOrgId",{"_33":61,"_13":14,"_45":149,"_63":-5,"_64":53,"_65":66,"_67":66,"_68":19,"_69":-5,"_70":71,"_72":-5,"_73":53,"_74":-5,"_75":-5,"_76":77,"_78":79,"_80":-5,"_81":-5,"_82":-5,"_83":-5,"_84":85,"_86":85,"_87":88,"_89":88,"_90":88,"_91":85,"_92":85,"_93":150,"_95":151,"_97":152,"_99":53},[146],"files",[146],"counts",{"_136":77,"_137":138,"_139":77,"_31":140,"_141":142},[134],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_33":34,"_13":35,"_36":37,"_38":-5,"_39":40,"_41":42,"_43":44,"_45":46,"_17":47,"_48":49,"_50":51,"_52":53,"_54":-5,"_18":135},[35],"pulls","branches",1,"forks",{"_143":77,"_145":77},"connections",{"_143":77,"_144":77},"count","unfilledCount","emptyCount",{"_33":34,"_13":35,"_36":37,"_38":-5,"_39":40,"_41":42,"_43":44,"_45":57,"_17":47,"_48":49,"_50":51,"_52":53,"_54":-5,"_58":147,"_18":148},[],[35],["D",1782666853853],{"_11":12,"_115":111},{"_11":12,"_108":109,"_110":111,"_70":71,"_112":113,"_114":53},{"_17":42,"_13":16,"_33":40,"_100":61,"_101":-5,"_102":-5,"_103":-5,"_104":-5,"_105":-5,"_106":14,"_107":12},"ctx",{"_93":-5,"_131":186,"_187":188,"_189":190,"_191":53,"_192":53,"_193":53,"_194":44,"_195":-5,"_196":-7,"_197":-7,"_198":77,"_199":53,"_200":53,"_201":-5,"_202":53,"_203":53,"_204":53,"_205":-5},"ENV",{"_157":158,"_159":160,"_161":16,"_162":163,"_164":165,"_166":167,"_168":169,"_170":171,"_172":173,"_174":175,"_176":177,"_178":179,"_180":181,"_182":183,"_184":185},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","71c1b20804b3232a7e513be260cfffc1932a9e97","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"]

Code