diff --git a/.env.example b/.env.example new file mode 100644 index 0000000..4beeeb7 --- /dev/null +++ b/.env.example @@ -0,0 +1,5 @@ +# shitsky saves state here +DATABASE_URL=postgres://postgres:postgres@localhost:5432/shitsky + +# shitsky is only going to care about the social circles of the users in these PDSes: +PDS_LIST=pds.witchcraft.systems,pds.upcloud.world diff --git a/.gitignore b/.gitignore index 8cf5f09..b691d12 100644 --- a/.gitignore +++ b/.gitignore @@ -1,2 +1,3 @@ /target /.sqlx +.env diff --git a/migrations/20251004130559_create_firehose_table.down.sql b/migrations/20251004130559_create_firehose_table.down.sql new file mode 100644 index 0000000..8d1bb7b --- /dev/null +++ b/migrations/20251004130559_create_firehose_table.down.sql @@ -0,0 +1 @@ +DROP TABLE firehose_messages; diff --git a/migrations/20251004130559_create_firehose_table.up.sql b/migrations/20251004130559_create_firehose_table.up.sql new file mode 100644 index 0000000..2217b50 --- /dev/null +++ b/migrations/20251004130559_create_firehose_table.up.sql @@ -0,0 +1,4 @@ +CREATE TABLE firehose_messages ( + created_at TIMESTAMP NOT NULL DEFAULT NOW(), + message JSONB NOT NULL +); diff --git a/src/firehose.rs b/src/firehose.rs index 77446f7..caff937 100644 --- a/src/firehose.rs +++ b/src/firehose.rs @@ -156,7 +156,7 @@ pub fn subscribe_repos( break; }, Ok(Some(Ok(msg))) => { - if let Message::Binary(data) = msg { + if let Message::Binary(data) = msg { let mut deserializer = serde_ipld_dagcbor::de::Deserializer::from_slice(&data); let map_cbor_err = |e: serde_ipld_dagcbor::DecodeError| { std::io::Error::other(e.to_string()) diff --git a/src/main.rs b/src/main.rs index 9f81032..fe04900 100644 --- a/src/main.rs +++ b/src/main.rs @@ -41,7 +41,7 @@ async fn firehose_subscriber(db: Db) { tracing::info!("Starting firehose subscriber..."); let options = FirehoseOptions { - relay_url: "wss://relay.upcloud.world".to_string(), + relay_url: "wss://bsky.network".to_string(), ..Default::default() };