diff --git a/sql/04_change_cursor_type_to_bigint.sql b/sql/04_change_cursor_type_to_bigint.sql new file mode 100644 index 0000000..8362449 --- /dev/null +++ b/sql/04_change_cursor_type_to_bigint.sql @@ -0,0 +1 @@ +ALTER TABLE SubscriptionState ALTER COLUMN cursor TYPE BIGINT; diff --git a/src/services/bluesky/client.rs b/src/services/bluesky/client.rs index 0d4fc81..30c6414 100644 --- a/src/services/bluesky/client.rs +++ b/src/services/bluesky/client.rs @@ -145,7 +145,7 @@ impl Bluesky { pub async fn subscribe_to_operations( &self, processor: &P, - cursor: Option, + cursor: Option, ) -> Result<()> { let url = match cursor { Some(cursor) => format!( diff --git a/src/services/database.rs b/src/services/database.rs index 1eedb49..c81c188 100644 --- a/src/services/database.rs +++ b/src/services/database.rs @@ -213,7 +213,7 @@ impl Database { .await?) } - pub async fn fetch_subscription_cursor(&self, host: &str, did: &str) -> Result> { + pub async fn fetch_subscription_cursor(&self, host: &str, did: &str) -> Result> { let mut params = Parameters::new(); Ok(query(