export default async function(req: Request): Promise { const url = new URL(req.url); const path = url.pathname; if (path === "/") { return new Response( `

Bluesky Feed: Posts Without 'E'

This feed includes all Bluesky posts that do not contain the letter 'E'.

/xrpc/app.bsky.feed.getFeedSkeleton

`, { headers: { "Content-Type": "text/html;charset=utf-8" } }, ); } if (path.startsWith("/xrpc/app.bsky.feed.getFeedSkeleton")) { // WebSocket-based Firehose const postsWithoutE = await getFilteredPosts(); return new Response( JSON.stringify({ feed: postsWithoutE }), { headers: { "Content-Type": "application/json;charset=utf-8" } }, ); } return new Response("Not Found", { status: 404 }); } // Firehose Function to Filter Posts async function getFilteredPosts() { return new Promise((resolve, reject) => { const ws = new WebSocket( "wss://jetstream2.us-east.bsky.network/subscribe?wantedCollections=app.bsky.feed.post", ); const filteredPosts = []; let messageCount = 0; ws.onmessage = (event) => { try { const data = JSON.parse(event.data); const postText = data.commit?.record?.text; const postUri = data.commit?.record?.uri; // Add posts without the letter "e" to the filtered array // if (postText && !postText.match(/e/i)) { // filteredPosts.push({ post: postUri }); // } filteredPosts.push({ post: postUri }); messageCount++; if (messageCount >= 50) { // Resolve after collecting 50 posts ws.close(); resolve(filteredPosts); } } catch (error) { console.error("Error parsing WebSocket message:", error); } }; ws.onerror = (error) => { console.error("WebSocket error:", error); ws.close(); reject(error); }; ws.onclose = () => { console.log("WebSocket connection closed."); }; }); }

elan