cargo fmt

Author: rudyfraser

rsky-common/src/lib.rs

@@ -1,2 +1,2 @@
 pub mod env;
-pub mod explicit_slurs;
+pub mod explicit_slurs;

rsky-feedgen/src/apis/mod.rs

@@ -1,6 +1,4 @@
-use rsky_common::env::env_int;
 use crate::db::*;
-use rsky_common::explicit_slurs::contains_explicit_slurs;
 use crate::models::create_request::CreateRecord;
 use crate::models::Lexicon::{AppBskyFeedFollow, AppBskyFeedLike, AppBskyFeedPost};
 use crate::models::*;
@@ -15,6 +13,8 @@ use once_cell::sync::Lazy;
 use rand::Rng;
 use regex::Regex;
 use rocket::State;
+use rsky_common::env::env_int;
+use rsky_common::explicit_slurs::contains_explicit_slurs;
 use rsky_lexicon::app::bsky::embed::{Embeds, MediaUnion};
 use rsky_lexicon::app::bsky::feed::PostLabels;
 use std::collections::HashSet;
@@ -1179,7 +1179,7 @@ mod tests {
                     show_sponsored_post: false,
                     sponsored_post_uri: "at://did:example/sponsored-post".to_string(),
                     sponsored_post_probability: 1.0,
-                    trending_percentile_min: 0.9
+                    trending_percentile_min: 0.9,
                 };
                 let rocket = before(config.clone());
 
@@ -1238,7 +1238,7 @@ mod tests {
                     show_sponsored_post: true,
                     sponsored_post_uri: "at://did:example/sponsored-post".to_string(),
                     sponsored_post_probability: 1.0,
-                    trending_percentile_min: 0.9
+                    trending_percentile_min: 0.9,
                 };
                 let rocket = before(config.clone());
 
@@ -1296,7 +1296,7 @@ mod tests {
                     show_sponsored_post: true,
                     sponsored_post_uri: "at://did:example/sponsored-post".to_string(),
                     sponsored_post_probability: 1.0,
-                    trending_percentile_min: 0.9
+                    trending_percentile_min: 0.9,
                 };
                 let rocket = before(config.clone());
 
@@ -1355,7 +1355,7 @@ mod tests {
                     show_sponsored_post: true,
                     sponsored_post_uri: "at://did:example/sponsored-post".to_string(),
                     sponsored_post_probability: 0.5,
-                    trending_percentile_min: 0.9
+                    trending_percentile_min: 0.9,
                 };
                 let rocket = before(config.clone());
 
@@ -1426,7 +1426,7 @@ mod tests {
                     show_sponsored_post: true,
                     sponsored_post_uri: "at://did:example/sponsored-post".to_string(),
                     sponsored_post_probability: 1.0,
-                    trending_percentile_min: 0.9
+                    trending_percentile_min: 0.9,
                 };
                 let rocket = before(config.clone());
 

rsky-labeler/src/main.rs

@@ -124,7 +124,7 @@ async fn get_labels(
 
 async fn label_subject(
     agent: &AtpAgent<MemorySessionStore, ReqwestClient>,
-    subject_ref: EmitEventInputSubjectRefs
+    subject_ref: EmitEventInputSubjectRefs,
 ) -> Result<(), Box<dyn std::error::Error>> {
     let label_result = agent
         .api
@@ -140,7 +140,8 @@ async fn label_subject(
                     ModEventLabel {
                         data: ModEventLabelData {
                             comment: Some(
-                                env::var("MOD_SERVICE_LABEL_REASON").unwrap_or("Explicit slur filter".to_string()),
+                                env::var("MOD_SERVICE_LABEL_REASON")
+                                    .unwrap_or("Explicit slur filter".to_string()),
                             ),
                             create_label_vals: vec![env::var("MOD_SERVICE_LABEL")
                                 .unwrap_or("antiblack-harassment".to_string())],
@@ -193,7 +194,7 @@ async fn tag_subject(
 async fn create_report(
     agent: &AtpAgent<MemorySessionStore, ReqwestClient>,
     subject_ref: EmitEventInputSubjectRefs,
-    reason: Option<String>
+    reason: Option<String>,
 ) -> Result<(), Box<dyn std::error::Error>> {
     let report_result = agent
         .api
@@ -362,17 +363,21 @@ async fn process(
                         continue;
                     }
                     if env_bool("ENABLE_CREATE_REPORT").unwrap_or(true) {
-                        match create_report(agent, auto_report.subject_ref.clone(), auto_report.reason).await {
+                        match create_report(
+                            agent,
+                            auto_report.subject_ref.clone(),
+                            auto_report.reason,
+                        )
+                        .await
+                        {
                             Ok(()) => (),
                             Err(error) => {
                                 eprintln!("@LOG: Failed to create report for record: {error:?}")
                             }
                         }
                     }
                     if env_bool("ENABLE_CREATE_LABEL").unwrap_or(true) {
-                        match label_subject(agent, auto_report.subject_ref.clone())
-                            .await
-                        {
+                        match label_subject(agent, auto_report.subject_ref.clone()).await {
                             Ok(()) => (),
                             Err(error) => eprintln!("@LOG: Failed to label record: {error:?}"),
                         }

rsky-lexicon/src/com/atproto/label/mod.rs

@@ -5,7 +5,7 @@ use chrono::{DateTime, Utc};
 #[derive(Debug, Serialize, Deserialize)]
 pub struct SubscribeLabels {
     pub seq: i64,
-    pub labels: Vec<Label>
+    pub labels: Vec<Label>,
 }
 
 /// Metadata tag on an atproto resource (eg, repo or record).