Alternative ATProto PDS implementation

cleanup

Changed files
+3 -12
src
+1 -2
src/actor_endpoints.rs
··· 9 routing::{get, post}, 10 }; 11 use constcat::concat; 12 - use diesel::prelude::*; 13 14 - use crate::{actor_store::ActorStore, auth::AuthenticatedUser}; 15 16 use super::serve::*; 17
··· 9 routing::{get, post}, 10 }; 11 use constcat::concat; 12 13 + use crate::auth::AuthenticatedUser; 14 15 use super::serve::*; 16
+1 -1
src/actor_store/blob_fs.rs
··· 4 use cidv10::Cid; 5 use rsky_common::get_random_str; 6 use rsky_repo::error::BlobError; 7 - use std::path::{Path, PathBuf}; 8 use std::str::FromStr; 9 use tokio::fs as async_fs; 10 use tokio::io::AsyncWriteExt;
··· 4 use cidv10::Cid; 5 use rsky_common::get_random_str; 6 use rsky_repo::error::BlobError; 7 + use std::path::PathBuf; 8 use std::str::FromStr; 9 use tokio::fs as async_fs; 10 use tokio::io::AsyncWriteExt;
+1 -9
src/oauth.rs
··· 367 let response_type = response_type.to_owned(); 368 let code_challenge = code_challenge.to_owned(); 369 let code_challenge_method = code_challenge_method.to_owned(); 370 - let state = state.map(|s| s.to_owned()); 371 - let login_hint = login_hint.map(|s| s.to_owned()); 372 - let scope = scope.map(|s| s.to_owned()); 373 - let redirect_uri = redirect_uri.map(|s| s.to_owned()); 374 - let response_mode = response_mode.map(|s| s.to_owned()); 375 - let display = display.map(|s| s.to_owned()); 376 - let created_at = created_at; 377 - let expires_at = expires_at; 378 _ = db 379 .get() 380 .await ··· 589 .interact(move |conn| { 590 AccountSchema::account 591 .filter(AccountSchema::email.eq(username_clone)) 592 - .first::<rsky_pds::models::Account>(conn) 593 .optional() 594 }) 595 .await
··· 367 let response_type = response_type.to_owned(); 368 let code_challenge = code_challenge.to_owned(); 369 let code_challenge_method = code_challenge_method.to_owned(); 370 _ = db 371 .get() 372 .await ··· 581 .interact(move |conn| { 582 AccountSchema::account 583 .filter(AccountSchema::email.eq(username_clone)) 584 + .first::<crate::models::pds::Account>(conn) 585 .optional() 586 }) 587 .await