diff --git a/src/processes/feed_server/endpoints/describe_feed_generator.rs b/src/processes/feed_server/endpoints/describe_feed_generator.rs index 582eb69..5d2e414 100644 --- a/src/processes/feed_server/endpoints/describe_feed_generator.rs +++ b/src/processes/feed_server/endpoints/describe_feed_generator.rs @@ -11,7 +11,10 @@ pub async fn describe_feed_generator( Json(FeedGeneratorDescription { did: state.config.service_did.clone(), feeds: vec![Feed { - uri: format!("at://{}/app.bsky.feed.generator/{}", state.config.publisher_did, "nederlandskie"), + uri: format!( + "at://{}/app.bsky.feed.generator/{}", + state.config.publisher_did, "nederlandskie" + ), }], links: None, }) diff --git a/src/processes/profile_classifier.rs b/src/processes/profile_classifier.rs index fcc1f83..b74c509 100644 --- a/src/processes/profile_classifier.rs +++ b/src/processes/profile_classifier.rs @@ -2,9 +2,9 @@ use std::time::Duration; use anyhow::Result; -use crate::services::AI; use crate::services::Bluesky; use crate::services::Database; +use crate::services::AI; pub struct ProfileClassifier<'a> { database: &'a Database, diff --git a/src/services/database.rs b/src/services/database.rs index cf9de42..8e387f6 100644 --- a/src/services/database.rs +++ b/src/services/database.rs @@ -1,6 +1,6 @@ use anyhow::Result; use chrono::{DateTime, Utc}; -use scooby::postgres::{insert_into, select, update, Joinable, Orderable, Parameters, Aliasable}; +use scooby::postgres::{insert_into, select, update, Aliasable, Joinable, Orderable, Parameters}; use sqlx::postgres::{PgPool, PgPoolOptions, PgRow}; use sqlx::query; use sqlx::Row; @@ -62,7 +62,8 @@ impl Database { let mut params = Parameters::new(); let mut sql_builder = select(("p.indexed_at", "p.author_did", "p.cid", "p.uri")) .from( - "Post".as_("p") + "Post" + .as_("p") .inner_join("Profile".as_("pr")) .on("pr.did = p.author_did"), ) @@ -78,8 +79,7 @@ impl Database { let sql_string = sql_builder.to_string(); - let mut query_object = query(&sql_string) - .bind(author_country); + let mut query_object = query(&sql_string).bind(author_country); if let Some((last_indexed_at, last_cid)) = earlier_than { query_object = query_object.bind(last_indexed_at).bind(last_cid);