phil jetstream instance

Author: orual

crates/pattern_core/src/config.rs

@@ -626,7 +626,7 @@ pub struct BlueskyConfig {
 }
 
 fn default_jetstream_endpoint() -> String {
-    "wss://jetstream1.us-west.bsky.network/subscribe".to_string()
+    "wss://jetstream1.us-east.fire.hose.cam/subscribe".to_string()
 }
 
 /// Model provider configuration

crates/pattern_core/src/data_source/bluesky.rs

@@ -3511,9 +3511,10 @@ impl DataSource for BlueskyFirehoseSource {
 
             // Standard Jetstream endpoints to rotate through
             let endpoints = vec![
+                "wss://jetstream1.us-east.fire.hose.cam/subscribe",
                 "wss://jetstream2.us-west.bsky.network/subscribe",
                 "wss://jetstream1.us-west.bsky.network/subscribe",
-                //"wss://jetstream2.us-east.bsky.network/subscribe",
+                "wss://jetstream2.us-east.bsky.network/subscribe",
                 "wss://jetstream1.us-east.bsky.network/subscribe",
             ];
             let mut current_endpoint_idx = 0;

crates/pattern_core/src/data_source/helpers.rs

@@ -105,7 +105,7 @@ where
     E: EmbeddingProvider + Clone + 'static,
 {
     let endpoint =
-        endpoint.unwrap_or_else(|| "wss://jetstream.fire.hose.cam/subscribe".to_string());
+        endpoint.unwrap_or_else(|| "wss://jetstream1.us-east.fire.hose.cam/subscribe".to_string());
 
     // Create a buffer with processing queue for rate limiting
     let buffer = StreamBuffer::new(1000, std::time::Duration::from_secs(3600)) // 1000 items, 1 hour