Struct mas_storage_pg::upstream_oauth2::PgUpstreamOAuthSessionRepository

pub struct PgUpstreamOAuthSessionRepository<'c> { /* private fields */ }

An implementation of [UpstreamOAuthSessionRepository] for a PostgreSQL connection

Implementations

impl<'c> PgUpstreamOAuthSessionRepository<'c>

pub fn new(conn: &'c mut PgConnection) -> Self

Create a new PgUpstreamOAuthSessionRepository from an active PostgreSQL connection

Trait Implementations

impl<'c> UpstreamOAuthSessionRepository for PgUpstreamOAuthSessionRepository<'c>

fn consume<'life0, 'life1, 'async_trait>( &'life0 mut self, clock: &'life1 dyn Clock, upstream_oauth_authorization_session: UpstreamOAuthAuthorizationSession, ) -> Pin<Box<dyn Future<Output = Result<UpstreamOAuthAuthorizationSession, Self::Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Mark a session as consumed

type Error = DatabaseError

The error type returned by the repository

fn lookup<'life0, 'async_trait>( &'life0 mut self, id: Ulid, ) -> Pin<Box<dyn Future<Output = Result<Option<UpstreamOAuthAuthorizationSession>, Self::Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Lookup a session by its ID

fn add<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 mut self, rng: &'life1 mut (dyn RngCore + Send), clock: &'life2 dyn Clock, upstream_oauth_provider: &'life3 UpstreamOAuthProvider, state_str: String, code_challenge_verifier: Option<String>, nonce: String, ) -> Pin<Box<dyn Future<Output = Result<UpstreamOAuthAuthorizationSession, Self::Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

Add a session to the database

fn complete_with_link<'life0, 'life1, 'life2, 'async_trait>( &'life0 mut self, clock: &'life1 dyn Clock, upstream_oauth_authorization_session: UpstreamOAuthAuthorizationSession, upstream_oauth_link: &'life2 UpstreamOAuthLink, id_token: Option<String>, extra_callback_parameters: Option<Value>, ) -> Pin<Box<dyn Future<Output = Result<UpstreamOAuthAuthorizationSession, Self::Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Mark a session as completed and associate the given link