tmp removed env for ws url and added commit filter

likeandscribe · Nov 14, 2024 · 0d1127c · 0d1127c
1 parent 6fbe9f9
commit 0d1127c
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 5 deletions.
diff --git a/packages-rs/drainpipe/.env b/packages-rs/drainpipe/.env
@@ -1,2 +1 @@
-FRONTPAGE_CONSUMER_URL="http://localhost:3000/api/receive_hook"
-JETSTREAM_URL="wss://jetstream1.us-east.bsky.network/subscribe"
+FRONTPAGE_CONSUMER_URL="http://localhost:3000/api/receive_hook"
diff --git a/packages-rs/drainpipe/src/main.rs b/packages-rs/drainpipe/src/main.rs
@@ -1,14 +1,14 @@
 use futures_util::stream::StreamExt;
-use std::env;
 use std::error::Error;
 use std::time::Duration;
 use tokio::time::timeout;
 use tokio_tungstenite::{connect_async, tungstenite::protocol::Message};
 
 #[tokio::main]
 async fn main() -> Result<(), Box<dyn Error>> {
-    let url = env::var("JETSTREAM_URL")
-        .unwrap_or("wss://jetstream1.us-west.bsky.network/subscribe".to_string());
+    let url =
+        "wss://jetstream1.us-west.bsky.network/subscribe?wantedCollections=fyi.unravel.frontpage"
+            .to_string();
 
     let mut reconnect_attempts = 0;
     let max_reconnect_attempts = 5;