From bac76a98bf4e90610d0a7105d2ebe6872dc147d4 Mon Sep 17 00:00:00 2001 From: rtkay123 Date: Mon, 9 Feb 2026 13:25:17 +0200 Subject: feat: svc crate --- lib/auth-service/src/client/mod.rs | 5 ++-- lib/auth-service/src/lib.rs | 2 ++ lib/auth-service/src/service/mod.rs | 51 +++++++++++++++++++++++++++++++++++++ 3 files changed, 56 insertions(+), 2 deletions(-) create mode 100644 lib/auth-service/src/service/mod.rs (limited to 'lib/auth-service/src') diff --git a/lib/auth-service/src/client/mod.rs b/lib/auth-service/src/client/mod.rs index af581b0..45e7e4d 100644 --- a/lib/auth-service/src/client/mod.rs +++ b/lib/auth-service/src/client/mod.rs @@ -5,6 +5,7 @@ use url::Url; use crate::AuthServiceError; +#[derive(Debug, Clone)] pub struct OauthClient( oauth2::basic::BasicClient< EndpointSet, @@ -38,10 +39,10 @@ impl ClientConfig { } } -impl TryFrom for OauthClient { +impl TryFrom<&ClientConfig> for OauthClient { type Error = AuthServiceError; - fn try_from(value: ClientConfig) -> Result { + fn try_from(value: &ClientConfig) -> Result { debug!("creating oauth client"); Ok(Self( oauth2::basic::BasicClient::new(ClientId::new(value.client_id.to_string())) diff --git a/lib/auth-service/src/lib.rs b/lib/auth-service/src/lib.rs index f7b9e80..308ce0f 100644 --- a/lib/auth-service/src/lib.rs +++ b/lib/auth-service/src/lib.rs @@ -1,4 +1,6 @@ pub mod client; +mod service; +pub use service::*; use thiserror::Error; diff --git a/lib/auth-service/src/service/mod.rs b/lib/auth-service/src/service/mod.rs new file mode 100644 index 0000000..3d45523 --- /dev/null +++ b/lib/auth-service/src/service/mod.rs @@ -0,0 +1,51 @@ +use async_session::{Result, Session, SessionStore}; +use async_trait::async_trait; +use shared_svc::cache::RedisManager; +use tracing::instrument; + +#[derive(Debug, Clone)] +pub struct AuthService { + cache: RedisManager, +} + +impl AuthService { + pub fn new(cache: &RedisManager) -> Self { + Self { + cache: cache.clone(), + } + } +} + +#[async_trait] +impl SessionStore for AuthService { + #[doc = " Get a session from the storage backend."] + #[doc = ""] + #[doc = " The input is expected to be the value of an identifying"] + #[doc = " cookie. This will then be parsed by the session middleware"] + #[doc = " into a session if possible"] + #[instrument(skip(self))] + async fn load_session(&self, cookie_value: String) -> Result> { + todo!() + } + + #[doc = " Store a session on the storage backend."] + #[doc = ""] + #[doc = " The return value is the value of the cookie to store for the"] + #[doc = " user that represents this session"] + #[instrument(skip(self))] + async fn store_session(&self, session: Session) -> Result> { + todo!() + } + + #[doc = " Remove a session from the session store"] + #[instrument(skip(self))] + async fn destroy_session(&self, session: Session) -> Result { + todo!() + } + + #[doc = " Empties the entire store, destroying all sessions"] + #[instrument(skip(self))] + async fn clear_store(&self) -> Result { + todo!() + } +} -- cgit v1.2.3