GKaszewski/pocket-chords
1
0
Fork 0
Code Issues 1 Pull Requests Actions Packages Projects Releases Wiki Activity

style: rustfmt

Browse Source
This commit is contained in:
Gabriel Kaszewski
2026-07-11 21:59:47 +02:00
parent 2b702d88e4
commit bfaea4a4b0
3 changed files with 8 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
crates/adapters/sqlite/src/repository.rs
View File

@@ -3,8 +3,8 @@ use domain::{
DomainError, Song, SongRepositoryPort, SongSummary, SortField, SortOrder, StoredSong, DomainError, Song, SongRepositoryPort, SongSummary, SortField, SortOrder, StoredSong,
song_preview_chords, song_preview_chords,
}; };
use std::str::FromStr;
use sqlx::SqlitePool; use sqlx::SqlitePool;
use std::str::FromStr;
use uuid::Uuid; use uuid::Uuid;
use crate::row::{SongRow, row_to_summary, sort_clause}; use crate::row::{SongRow, row_to_summary, sort_clause};
@@ -16,8 +16,8 @@ pub struct SqliteSongRepository {
impl SqliteSongRepository { impl SqliteSongRepository {
pub async fn new(database_url: &str) -> Result<Self, sqlx::Error> { pub async fn new(database_url: &str) -> Result<Self, sqlx::Error> {
let opts = sqlx::sqlite::SqliteConnectOptions::from_str(database_url)? let opts =
.create_if_missing(true); sqlx::sqlite::SqliteConnectOptions::from_str(database_url)?.create_if_missing(true);
let pool = SqlitePool::connect_with(opts).await?; let pool = SqlitePool::connect_with(opts).await?;
sqlx::migrate!("./migrations").run(&pool).await?; sqlx::migrate!("./migrations").run(&pool).await?;
Ok(Self { pool }) Ok(Self { pool })

6
crates/application/src/auth/login.rs
View File

@@ -17,11 +17,7 @@ pub struct LoginResult {
pub async fn execute(deps: &LoginDeps, cmd: LoginCommand) -> Result<LoginResult, DomainError> { pub async fn execute(deps: &LoginDeps, cmd: LoginCommand) -> Result<LoginResult, DomainError> {
let email = Email::new(&cmd.email)?; let email = Email::new(&cmd.email)?;
let user = deps let user = deps.user_repo.find_by_email(&email).await?.ok_or_else(|| {
.user_repo
.find_by_email(&email)
.await?
.ok_or_else(|| {
tracing::warn!(email = cmd.email, "login attempt with unknown email"); tracing::warn!(email = cmd.email, "login attempt with unknown email");
DomainError::Unauthorized("invalid credentials".into()) DomainError::Unauthorized("invalid credentials".into())
})?; })?;

4
crates/application/src/auth/register.rs
View File

@@ -8,9 +8,7 @@ use super::deps::RegisterDeps;
pub async fn execute(deps: &RegisterDeps, cmd: RegisterCommand) -> Result<(), DomainError> { pub async fn execute(deps: &RegisterDeps, cmd: RegisterCommand) -> Result<(), DomainError> {
if !deps.allow_registration { if !deps.allow_registration {
tracing::warn!("registration attempt while disabled"); tracing::warn!("registration attempt while disabled");
return Err(DomainError::Unauthorized( return Err(DomainError::Unauthorized("registration is disabled".into()));
"registration is disabled".into(),
));
} }
let password = Password::new(&cmd.password)?; let password = Password::new(&cmd.password)?;