db

Documentation

Index

• func New() func(gas.DatabaseProvider, gas.Logger, gas.MigrationManager) *Store
• type Store
  • func (s *Store) ConsumeTokenByHash(ctx context.Context, tokenHash string) (*TokenRecord, error)
  • func (s *Store) DeleteExpiredTokens(ctx context.Context, before time.Time) (int64, error)
  • func (s *Store) DeleteTokenByHash(ctx context.Context, tokenHash string) (int64, error)
  • func (s *Store) DeleteTokensBySubjectPurpose(ctx context.Context, subject, purpose string) error
  • func (s *Store) Init(serviceName string) error
  • func (s *Store) InsertToken(ctx context.Context, id, subject, tokenHash, purpose string, ...) error
• type TokenRecord

Functions

func New

func New() func(gas.DatabaseProvider, gas.Logger, gas.MigrationManager) *Store

New returns a DI-injectable constructor for Store.

Types

type Store

type Store struct {
	// contains filtered or unexported fields
}

Store is a database-backed token store. It delegates to sqlc-generated queries and selects the correct dialect adapter at init time.

func (*Store) ConsumeTokenByHash

func (s *Store) ConsumeTokenByHash(ctx context.Context, tokenHash string) (*TokenRecord, error)

ConsumeTokenByHash atomically fetches and deletes a token by its hash, returning the record of the deleted row. Returns (nil, nil) if the token does not exist or was consumed concurrently by another caller.

func (*Store) DeleteExpiredTokens

func (s *Store) DeleteExpiredTokens(ctx context.Context, before time.Time) (int64, error)

DeleteExpiredTokens deletes tokens that expired before the given time.

func (*Store) DeleteTokenByHash

func (s *Store) DeleteTokenByHash(ctx context.Context, tokenHash string) (int64, error)

DeleteTokenByHash deletes a token by its hash and returns rows affected.

func (*Store) DeleteTokensBySubjectPurpose

func (s *Store) DeleteTokensBySubjectPurpose(ctx context.Context, subject, purpose string) error

DeleteTokensBySubjectPurpose deletes all tokens for a subject with a given purpose.

func (*Store) Init

func (s *Store) Init(serviceName string) error

Init selects the correct sqlc adapter and registers migrations.

func (*Store) InsertToken

func (s *Store) InsertToken(ctx context.Context, id, subject, tokenHash, purpose string, createdAt, expiresAt time.Time) error

InsertToken stores a new token record.

type TokenRecord

type TokenRecord struct {
	ExpiresAt time.Time
	ID        string
	Subject   string
	Purpose   string
}

TokenRecord holds the data returned when looking up a token.