From 146055eca21ac3f993f33814abe6627bdc6cc658 Mon Sep 17 00:00:00 2001 From: phoenix Date: Wed, 22 Oct 2025 11:15:34 -0400 Subject: [PATCH] tsk-69: repo module changes --- src/repo/mod.rs | 55 ++------------------------------------------- src/repo/service.rs | 50 +++++++++++++++++++++++++++++++++++++++++ 2 files changed, 52 insertions(+), 53 deletions(-) create mode 100644 src/repo/service.rs diff --git a/src/repo/mod.rs b/src/repo/mod.rs index b61cc7b..15482e9 100644 --- a/src/repo/mod.rs +++ b/src/repo/mod.rs @@ -1,3 +1,5 @@ +pub mod service; + pub mod user { use sqlx::Row; @@ -195,56 +197,3 @@ pub mod salt { } } } - -pub mod service { - use sqlx::Row; - - pub async fn valid_passphrase( - pool: &sqlx::PgPool, - passphrase: &String, - ) -> Result<(uuid::Uuid, String, time::OffsetDateTime), sqlx::Error> { - let result = sqlx::query( - r#" - SELECT id, username, date_created FROM "passphrase" WHERE passphrase = $1 - "#, - ) - .bind(passphrase) - .fetch_one(pool) - .await; - - match result { - Ok(row) => { - let id: uuid::Uuid = row.try_get("id")?; - let username: String = row.try_get("username")?; - let date_created: Option = row.try_get("date_created")?; - - Ok((id, username, date_created.unwrap())) - } - Err(err) => Err(err), - } - } - - pub async fn get_passphrase( - pool: &sqlx::PgPool, - id: &uuid::Uuid, - ) -> Result<(String, String, time::OffsetDateTime), sqlx::Error> { - let result = sqlx::query( - r#" - SELECT username, passphrase, date_created FROM "passphrase" WHERE id = $1; - "#, - ) - .bind(id) - .fetch_one(pool) - .await; - - match result { - Ok(row) => { - let username: String = row.try_get("username")?; - let passphrase: String = row.try_get("passphrase")?; - let date_created: time::OffsetDateTime = row.try_get("date_created")?; - Ok((username, passphrase, date_created)) - } - Err(err) => Err(err), - } - } -} diff --git a/src/repo/service.rs b/src/repo/service.rs new file mode 100644 index 0000000..14ced65 --- /dev/null +++ b/src/repo/service.rs @@ -0,0 +1,50 @@ +use sqlx::Row; + +pub async fn valid_passphrase( + pool: &sqlx::PgPool, + passphrase: &String, +) -> Result<(uuid::Uuid, String, time::OffsetDateTime), sqlx::Error> { + let result = sqlx::query( + r#" + SELECT id, username, date_created FROM "passphrase" WHERE passphrase = $1 + "#, + ) + .bind(passphrase) + .fetch_one(pool) + .await; + + match result { + Ok(row) => { + let id: uuid::Uuid = row.try_get("id")?; + let username: String = row.try_get("username")?; + let date_created: Option = row.try_get("date_created")?; + + Ok((id, username, date_created.unwrap())) + } + Err(err) => Err(err), + } +} + +pub async fn get_passphrase( + pool: &sqlx::PgPool, + id: &uuid::Uuid, +) -> Result<(String, String, time::OffsetDateTime), sqlx::Error> { + let result = sqlx::query( + r#" + SELECT username, passphrase, date_created FROM "passphrase" WHERE id = $1; + "#, + ) + .bind(id) + .fetch_one(pool) + .await; + + match result { + Ok(row) => { + let username: String = row.try_get("username")?; + let passphrase: String = row.try_get("passphrase")?; + let date_created: time::OffsetDateTime = row.try_get("date_created")?; + Ok((username, passphrase, date_created)) + } + Err(err) => Err(err), + } +}