From f02896b728e0f533db532dd8a641233a9a6dffe6 Mon Sep 17 00:00:00 2001 From: Tangled Date: Sat, 4 Oct 2025 18:41:35 +0000 Subject: [PATCH] Initial db migrations (forgor in last PR) Forgor to `git add -N` the migration files in last PR sorry! --- .env.example | 5 +++++ .gitignore | 1 + migrations/20251004130559_create_firehose_table.down.sql | 1 + migrations/20251004130559_create_firehose_table.up.sql | 4 ++++ src/firehose.rs | 2 +- src/main.rs | 2 +- 6 files changed, 13 insertions(+), 2 deletions(-) create mode 100644 .env.example create mode 100644 migrations/20251004130559_create_firehose_table.down.sql create mode 100644 migrations/20251004130559_create_firehose_table.up.sql 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() }; -- 2.51.2