/** @jsxImportSource https://esm.sh/react */ import React, { useState } from "https://esm.sh/react"; import { createRoot } from "https://esm.sh/react-dom/client"; function App() { const [handle, setHandle] = useState(""); const [password, setPassword] = useState(""); const [message, setMessage] = useState(""); const [isLoading, setIsLoading] = useState(false); const handleSubmit = async (e) => { e.preventDefault(); setIsLoading(true); setMessage(""); try { const response = await fetch("/subscribe", { method: "POST", headers: { "Content-Type": "application/json", }, body: JSON.stringify({ handle, password }), }); const result = await response.json(); if (response.ok) { setMessage("✅ Successfully subscribed to feed!"); } else { setMessage(`❌ Error: ${result.error}`); } } catch (error) { setMessage(`❌ Network error: ${error.message}`); } finally { setIsLoading(false); } }; return (

🔍 Posts Without 'E' Feed

{message && (

{message}

)}

); } function client() { createRoot(document.getElementById("root")).render(); } if (typeof document !== "undefined") { client(); } export default async function server(request: Request): Promise { const url = new URL(request.url); const path = url.pathname; if (path === "/") { return new Response( ` Bluesky Feed Subscription

`, { headers: { "Content-Type": "text/html;charset=utf-8" }, }, ); } if (path === "/subscribe" && request.method === "POST") { try { const { handle, password } = await request.json(); // Authenticate with Bluesky const authResponse = await fetch("https://bsky.social/xrpc/com.atproto.server.createSession", { method: "POST", headers: { "Content-Type": "application/json", }, body: JSON.stringify({ identifier: handle, password }), }); if (!authResponse.ok) { return new Response(JSON.stringify({ error: "Authentication failed" }), { status: 401, headers: { "Content-Type": "application/json" }, }); } const { did, accessJwt } = await authResponse.json(); // Subscribe to the feed const feedSubscriptionResponse = await fetch("https://bsky.social/xrpc/app.bsky.feed.subscribeFeed", { method: "POST", headers: { "Content-Type": "application/json", "Authorization": `Bearer ${accessJwt}`, }, body: JSON.stringify({ feed: `${url.origin}/xrpc/app.bsky.feed.getFeedSkeleton`, }), }); if (!feedSubscriptionResponse.ok) { const error = await feedSubscriptionResponse.text(); return new Response(JSON.stringify({ error: "Feed subscription failed " + error }), { status: 500, headers: { "Content-Type": "application/json" }, }); } return new Response(JSON.stringify({ success: true }), { headers: { "Content-Type": "application/json" }, }); } catch (error) { return new Response(JSON.stringify({ error: error.message }), { status: 500, headers: { "Content-Type": "application/json" }, }); } } if (path.startsWith("/xrpc/app.bsky.feed.getFeedSkeleton")) { 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?.cid; if (postUri) { filteredPosts.push({ post: postUri }); console.log(data); messageCount++; } if (messageCount >= 50) { 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."); }; }); }

feeds