synced/rsky
1
0
Fork 0
mirror of https://github.com/blacksky-algorithms/rsky.git synced 2025-03-14 13:59:02 +00:00
Code Issues Packages Projects Releases Wiki Activity

Changed default value for jetstream subscriber

Browse Source
This commit is contained in:
Ripperoni
2025-01-24 20:04:49 -08:00
committed by trentoncoleman
parent adfc16f6d3
commit 5288b59cc9
2 changed files with 8 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
.idea/dataSources.xml generated
View File

@ -8,5 +8,12 @@
<jdbc-url>jdbc:postgresql://localhost:5432/rsky_local</jdbc-url>
<working-dir>$ProjectFileDir$</working-dir>
</data-source>
<data-source source="LOCAL" name="postgres@localhost" uuid="649b6bf5-aca8-44eb-b190-abd2d223fa62">
<driver-ref>postgresql</driver-ref>
<synchronize>true</synchronize>
<jdbc-driver>org.postgresql.Driver</jdbc-driver>
<jdbc-url>jdbc:postgresql://localhost:5432/postgres</jdbc-url>
<working-dir>$ProjectFileDir$</working-dir>
</data-source>
</component>
</project>

2
rsky-jetstream/src/main.rs
View File

@ -300,7 +300,7 @@ async fn main() {
let default_subscriber_path = env::var("JETSTREAM_SERVER_ENDPOINT")
.unwrap_or("wss://jetstream1.us-west.bsky.network".into());
let wanted_collections = env::var("FILTER_PARAM")
.unwrap_or("wantedCollections=app.bsky.feed.post&wantedCollections=app.bsky.feed.repost&wantedCollections=app.bsky.graph.follow&wantedCollections=app.bsky.feed.like".into());
.unwrap_or("".into());
let client = reqwest::Client::new();
let subscriber = tracing_subscriber::FmtSubscriber::new();
tracing::subscriber::set_global_default(subscriber).unwrap();