Struct PostgresAccountStore 

pub struct PostgresAccountStore { /* private fields */ }

PostgreSQL-backed account store.

Persists user accounts and their linked provider identities, so account linking survives a process restart. See the module-level documentation for the schema and RLS posture.

Implementations

impl PostgresAccountStore

pub const fn new(db: PgPool) -> Self

Create a new store over an existing pool.

The pool’s role must own (or BYPASSRLS) the core.tb_user / core.tb_auth_identity tables — it runs the trusted login path and must not be constrained by the deny-by-default RLS. Calling init once on startup creates the tables (so the connecting role owns them by construction).

pub async fn init(&self) -> Result<()>

Create the core.tb_user / core.tb_auth_identity schema (idempotent).

Call once on startup. Safe to re-run and safe on a database that predates this store (the CREATE … IF NOT EXISTS form is the back-compat path for existing deployments that have no user table).

Errors

Returns AuthError::DatabaseError if the DDL fails.

Trait Implementations

impl AccountStore for PostgresAccountStore

fn link_or_create_user<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, email: Option<&'life1 str>, email_verified: bool, provider: &'life2 str, provider_id: &'life3 str, ) -> Pin<Box<dyn Future<Output = Result<AccountLinkResult>> + Send + 'async_trait>>

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

Return the user_id for the given identity, creating or linking as needed.

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

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

Look up the full account record for a user_id.