const EXCLUDES = [ "elon", "facebook", "musk", "zuckerberg", ]; export default async function(req: Request): Promise { const host = "nate-feeds.web.val.run"; const endpoint = `https://${host}`; 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" } }, ); } if (path === "/.well-known/did.json") { return new Response( `{"id":"did:web:${host}","service":[{"id":"#bsky_fg","type":"BskyFeedGenerator","serviceEndpoint":"${endpoint}"}]}`, { headers: { "Content-Type": "application/json" } }, ); } return new Response("Not Found", { status: 404 }); } function myFilter(text: string) { for (const exclude in EXCLUDES) { if (text.includes(exclude)) { return false; } } return true; } // 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: any[] = []; let messageCount = 0; ws.onmessage = (event) => { try { const data = JSON.parse(event.data); const postText = data.commit?.record?.text; const postUri = `at://${data.did}/${data.commit?.collection}/${data.commit?.rkey}`; if (postText && myFilter(postText)) { filteredPosts.push({ post: postUri }); } messageCount++; if (messageCount >= 50) { // Resolve after collecting 50 posts ws.close(); console.log(filteredPosts); 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."); }; }); }