Struct PostgresStorage

pub struct PostgresStorage { /* private fields */ }

Implementations

impl PostgresStorage

pub fn new(pool: PgPool) -> Self

pub async fn connect(database_url: &str) -> Result<Self, StorageError>

pub async fn migrate(&self) -> Result<(), StorageError>

Trait Implementations

impl Clone for PostgresStorage

fn clone(&self) -> PostgresStorage

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for PostgresStorage

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl OAuthStorage for PostgresStorage

fn create_oauth_account<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, provider: &'life1 str, subject: &'life2 str, user_id: &'life3 UserId, ) -> Pin<Box<dyn Future<Output = Result<OAuthAccount, Error>> + Send + 'async_trait>>

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

Create a new OAuth account linked to a user

fn store_pkce_verifier<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, csrf_state: &'life1 str, pkce_verifier: &'life2 str, expires_in: Duration, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

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

Store a PKCE verifier with an expiration time

fn get_pkce_verifier<'life0, 'life1, 'async_trait>( &'life0 self, csrf_state: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<String>, Error>> + Send + 'async_trait>>

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

Retrieve a stored PKCE verifier by CSRF state

fn get_oauth_account_by_provider_and_subject<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, provider: &'life1 str, subject: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<Option<OAuthAccount>, Error>> + Send + 'async_trait>>

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

Find an OAuth account by provider and subject

fn get_user_by_provider_and_subject<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, provider: &'life1 str, subject: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<Option<User>, Error>> + Send + 'async_trait>>

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

Find a user by their OAuth provider and subject

fn link_oauth_account<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, user_id: &'life1 UserId, provider: &'life2 str, subject: &'life3 str, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

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

Link an existing user to an OAuth account

impl PasskeyStorage for PostgresStorage

fn add_passkey<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, user_id: &'life1 UserId, credential_id: &'life2 str, passkey_json: &'life3 str, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

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

Add a passkey credential for a user

fn get_passkey_by_credential_id<'life0, 'life1, 'async_trait>( &'life0 self, credential_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<String>, Error>> + Send + 'async_trait>>

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

Get a passkey by credential ID

fn get_passkeys<'life0, 'life1, 'async_trait>( &'life0 self, user_id: &'life1 UserId, ) -> Pin<Box<dyn Future<Output = Result<Vec<String>, Error>> + Send + 'async_trait>>

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

Get all passkeys for a user

fn set_passkey_challenge<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, challenge_id: &'life1 str, challenge: &'life2 str, expires_in: Duration, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

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

Set a passkey challenge for a user

fn get_passkey_challenge<'life0, 'life1, 'async_trait>( &'life0 self, challenge_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<String>, Error>> + Send + 'async_trait>>

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

Get a passkey challenge

impl PasswordStorage for PostgresStorage

fn set_password_hash<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, user_id: &'life1 UserId, hash: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

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

Store a password hash for a user

fn get_password_hash<'life0, 'life1, 'async_trait>( &'life0 self, user_id: &'life1 UserId, ) -> Pin<Box<dyn Future<Output = Result<Option<String>, Error>> + Send + 'async_trait>>

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

Retrieve a user’s password hash

impl SessionStorage for PostgresStorage

fn create_session<'life0, 'life1, 'async_trait>( &'life0 self, session: &'life1 Session, ) -> Pin<Box<dyn Future<Output = Result<Session, Error>> + Send + 'async_trait>>

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

fn get_session<'life0, 'life1, 'async_trait>( &'life0 self, token: &'life1 SessionToken, ) -> Pin<Box<dyn Future<Output = Result<Option<Session>, Error>> + Send + 'async_trait>>

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

fn delete_session<'life0, 'life1, 'async_trait>( &'life0 self, token: &'life1 SessionToken, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

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

fn cleanup_expired_sessions<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

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

fn delete_sessions_for_user<'life0, 'life1, 'async_trait>( &'life0 self, user_id: &'life1 UserId, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

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

impl UserStorage for PostgresStorage

fn create_user<'life0, 'life1, 'async_trait>( &'life0 self, user: &'life1 NewUser, ) -> Pin<Box<dyn Future<Output = Result<User, Error>> + Send + 'async_trait>>

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

fn get_user<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 UserId, ) -> Pin<Box<dyn Future<Output = Result<Option<User>, Error>> + Send + 'async_trait>>

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

fn get_user_by_email<'life0, 'life1, 'async_trait>( &'life0 self, email: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<User>, Error>> + Send + 'async_trait>>

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

fn get_or_create_user_by_email<'life0, 'life1, 'async_trait>( &'life0 self, email: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<User, Error>> + Send + 'async_trait>>

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

fn update_user<'life0, 'life1, 'async_trait>( &'life0 self, user: &'life1 User, ) -> Pin<Box<dyn Future<Output = Result<User, Error>> + Send + 'async_trait>>

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

fn delete_user<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 UserId, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

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

fn set_user_email_verified<'life0, 'life1, 'async_trait>( &'life0 self, user_id: &'life1 UserId, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

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