🔍 Posts Without 'E' Feed

\n Bluesky Handle:\n setHandle(e.target.value)}\n placeholder=\"username.bsky.social\"\n required\n style={{ width: \"100%\", padding: \"8px\", marginTop: \"5px\" }}\n />\n

\n App Password:\n setPassword(e.target.value)}\n placeholder=\"Your Bluesky App Password\"\n required\n style={{ width: \"100%\", padding: \"8px\", marginTop: \"5px\" }}\n />\n

\n \n {isLoading ? \"Subscribing...\" : \"Subscribe to Feed\"}\n \n \n {message && (\n \n {message}\n \n )}\n \n );\n}\n\nfunction client() {\n createRoot(document.getElementById(\"root\")).render();\n}\nif (typeof document !== \"undefined\") { client(); }\n\nexport default async function server(request: Request): Promise {\n const url = new URL(request.url);\n const path = url.pathname;\n\n if (path === \"/\") {\n return new Response(\n `\n \n \n \n Bluesky Feed Subscription\n \n \n \n \n

\n \n \n \n `,\n {\n headers: { \"Content-Type\": \"text/html;charset=utf-8\" },\n },\n );\n }\n\n if (path === \"/subscribe\" && request.method === \"POST\") {\n try {\n const { handle, password } = await request.json();\n\n // Authenticate with Bluesky\n const authResponse = await fetch(\"https://bsky.social/xrpc/com.atproto.server.createSession\", {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({ identifier: handle, password }),\n });\n\n if (!authResponse.ok) {\n return new Response(JSON.stringify({ error: \"Authentication failed\" }), {\n status: 401,\n headers: { \"Content-Type\": \"application/json\" },\n });\n }\n\n const { did, accessJwt } = await authResponse.json();\n\n // Subscribe to the feed\n const feedSubscriptionResponse = await fetch(\"https://bsky.social/xrpc/app.bsky.feed.subscribeFeed\", {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n \"Authorization\": `Bearer ${accessJwt}`,\n },\n body: JSON.stringify({\n feed: `${url.origin}/xrpc/app.bsky.feed.getFeedSkeleton`,\n }),\n });\n\n if (!feedSubscriptionResponse.ok) {\n const error = await feedSubscriptionResponse.text();\n return new Response(JSON.stringify({ error: \"Feed subscription failed \" + error }), {\n status: 500,\n headers: { \"Content-Type\": \"application/json\" },\n });\n }\n\n return new Response(JSON.stringify({ success: true }), {\n headers: { \"Content-Type\": \"application/json\" },\n });\n } catch (error) {\n return new Response(JSON.stringify({ error: error.message }), {\n status: 500,\n headers: { \"Content-Type\": \"application/json\" },\n });\n }\n }\n\n if (path.startsWith(\"/xrpc/app.bsky.feed.getFeedSkeleton\")) {\n const postsWithoutE = await getFilteredPosts();\n return new Response(\n JSON.stringify({ feed: postsWithoutE }),\n { headers: { \"Content-Type\": \"application/json;charset=utf-8\" } },\n );\n }\n\n return new Response(\"Not Found\", { status: 404 });\n}\n\n// Firehose Function to Filter Posts\nasync function getFilteredPosts() {\n return new Promise((resolve, reject) => {\n const ws = new WebSocket(\n \"wss://jetstream2.us-east.bsky.network/subscribe?wantedCollections=app.bsky.feed.post\",\n );\n\n const filteredPosts = [];\n let messageCount = 0;\n\n ws.onmessage = (event) => {\n try {\n const data = JSON.parse(event.data);\n\n const postText = data.commit?.record?.text;\n const postUri = data.commit?.cid;\n\n if (postUri) {\n filteredPosts.push({ post: postUri });\n console.log(data);\n messageCount++;\n }\n if (messageCount >= 50) {\n ws.close();\n resolve(filteredPosts);\n }\n } catch (error) {\n console.error(\"Error parsing WebSocket message:\", error);\n }\n };\n\n ws.onerror = (error) => {\n console.error(\"WebSocket error:\", error);\n ws.close();\n reject(error);\n };\n\n ws.onclose = () => {\n console.log(\"WebSocket connection closed.\");\n };\n });\n}","deleted","label",[98],"permalink","https://www.val.town/x/stef/feeds/code/main.tsx","extension","actionData","errors"]