mongo

Feb 27, 2025

Changes in this version

type Config

+ Replicaset string

Feb 24, 2025

Changes in this version

type RequestManager

+ func (r *RequestManager) RotateRefreshToken(ctx context.Context, entityName string, requestID string) error

May 9, 2023

Changes in this version

type Config

+ CollectionPrefix string

Mar 26, 2022

Changes in this version

type ClientManager

+ func (c *ClientManager) IsJWTUsed(ctx context.Context, jti string) (bool, error)

+ func (c *ClientManager) MarkJWTUsedForTime(ctx context.Context, jti string, exp time.Time) error

type DeniedJtiManager

+ AccessTokenRequestIDs map[string]string

+ BlacklistedJTIs map[string]time.Time

+ RefreshTokenRequestIDs map[string]string

+ func (d *DeniedJtiManager) ClientAssertionJWTValid(_ context.Context, jti string) error

+ func (d *DeniedJtiManager) SetClientAssertionJWT(_ context.Context, jti string, exp time.Time) error

+ type IssuerPublicKeys struct

+ Issuer string

+ KeysBySub map[string]SubjectPublicKeys

+ type PublicKeyScopes struct

+ Key *jose.JSONWebKey

+ Scopes []string

type RequestManager

+ IssuerPublicKeys map[string]IssuerPublicKeys

+ func (r *RequestManager) GetPublicKey(ctx context.Context, issuer string, subject string, keyId string) (*jose.JSONWebKey, error)

+ func (r *RequestManager) GetPublicKeyScopes(ctx context.Context, issuer string, subject string, keyId string) ([]string, error)

+ func (r *RequestManager) GetPublicKeys(ctx context.Context, issuer string, subject string) (*jose.JSONWebKeySet, error)

+ func (r *RequestManager) RevokeRefreshTokenMaybeGracePeriod(ctx context.Context, requestID string, signature string) error

+ type SubjectPublicKeys struct

+ Keys map[string]PublicKeyScopes

+ Subject string

Mar 26, 2022

Changes in this version

+ const IdxClientID

+ const IdxCompoundRequester

+ const IdxExpires

+ const IdxExpiry

+ const IdxSessionID

+ const IdxSignatureID

+ const IdxUserID

+ const IdxUsername

+ func Connect(cfg *Config) (*mongo.Database, error)

+ func ConnectionInfo(cfg *Config) *options.ClientOptions

+ func ContextToSession(ctx context.Context) (sess mongo.Session, ok bool)

+ func NewExpiryIndex(name string, key string, expireAfter int) (model mongo.IndexModel)

+ func NewIndex(name string, keys ...string) (model mongo.IndexModel)

+ func NewUniqueIndex(name string, keys ...string) mongo.IndexModel

+ func SessionToContext(ctx context.Context, session mongo.Session) context.Context

+ func SetDebug(isDebug bool)

+ func SetLogger(log *logrus.Logger)

+ type ClientManager struct

+ DB *DB

+ DeniedJTIs storage.DeniedJTIStorer

+ Hasher fosite.Hasher

+ func (c *ClientManager) Authenticate(ctx context.Context, clientID string, secret string) (result storage.Client, err error)

+ func (c *ClientManager) AuthenticateMigration(ctx context.Context, currentAuth storage.AuthClientFunc, clientID string, ...) (result storage.Client, err error)

+ func (c *ClientManager) ClientAssertionJWTValid(ctx context.Context, jti string) error

+ func (c *ClientManager) Configure(ctx context.Context) (err error)

+ func (c *ClientManager) Create(ctx context.Context, client storage.Client) (result storage.Client, err error)

+ func (c *ClientManager) Delete(ctx context.Context, clientID string) (err error)

+ func (c *ClientManager) Get(ctx context.Context, clientID string) (result storage.Client, err error)

+ func (c *ClientManager) GetClient(ctx context.Context, clientID string) (fosite.Client, error)

+ func (c *ClientManager) GrantScopes(ctx context.Context, clientID string, scopes []string) (result storage.Client, err error)

+ func (c *ClientManager) List(ctx context.Context, filter storage.ListClientsRequest) (results []storage.Client, err error)

+ func (c *ClientManager) Migrate(ctx context.Context, migratedClient storage.Client) (result storage.Client, err error)

+ func (c *ClientManager) RemoveScopes(ctx context.Context, clientID string, scopes []string) (result storage.Client, err error)

+ func (c *ClientManager) SetClientAssertionJWT(ctx context.Context, jti string, exp time.Time) (err error)

+ func (c *ClientManager) Update(ctx context.Context, clientID string, updatedClient storage.Client) (result storage.Client, err error)

+ type Config struct

+ AuthDB string

+ Compressors []string

+ DatabaseName string

+ Hostnames []string

+ Password string

+ PoolMaxSize uint64

+ PoolMinSize uint64

+ Port uint16

+ Replset string

+ SSL bool

+ TLSConfig *tls.Config

+ Timeout uint

+ TokenTTL uint32

+ Username string

+ func DefaultConfig() *Config

+ type DB struct

+ type DeniedJtiManager struct

+ DB *DB

+ func (d *DeniedJtiManager) Configure(ctx context.Context) (err error)

+ func (d *DeniedJtiManager) Create(ctx context.Context, deniedJTI storage.DeniedJTI) (result storage.DeniedJTI, err error)

+ func (d *DeniedJtiManager) Delete(ctx context.Context, jti string) (err error)

+ func (d *DeniedJtiManager) DeleteBefore(ctx context.Context, expBefore int64) (err error)

+ func (d *DeniedJtiManager) Get(ctx context.Context, signature string) (result storage.DeniedJTI, err error)

+ type RequestManager struct

+ Clients storage.ClientStorer

+ DB *DB

+ Users storage.UserStorer

+ func (r *RequestManager) Authenticate(ctx context.Context, username string, secret string) (err error)

+ func (r *RequestManager) Configure(ctx context.Context) (err error)

+ func (r *RequestManager) ConfigureExpiryWithTTL(ctx context.Context, ttl int) error

+ func (r *RequestManager) Create(ctx context.Context, entityName string, request storage.Request) (result storage.Request, err error)

+ func (r *RequestManager) CreateAccessTokenSession(ctx context.Context, signature string, request fosite.Requester) (err error)

+ func (r *RequestManager) CreateAuthorizeCodeSession(ctx context.Context, code string, request fosite.Requester) (err error)

+ func (r *RequestManager) CreateOpenIDConnectSession(ctx context.Context, authorizeCode string, request fosite.Requester) (err error)

+ func (r *RequestManager) CreatePKCERequestSession(ctx context.Context, signature string, request fosite.Requester) (err error)

+ func (r *RequestManager) CreateRefreshTokenSession(ctx context.Context, signature string, request fosite.Requester) (err error)

+ func (r *RequestManager) Delete(ctx context.Context, entityName string, requestID string) (err error)

+ func (r *RequestManager) DeleteAccessTokenSession(ctx context.Context, signature string) (err error)

+ func (r *RequestManager) DeleteBySignature(ctx context.Context, entityName string, signature string) (err error)

+ func (r *RequestManager) DeleteOpenIDConnectSession(ctx context.Context, authorizeCode string) (err error)

+ func (r *RequestManager) DeletePKCERequestSession(ctx context.Context, signature string) (err error)

+ func (r *RequestManager) DeleteRefreshTokenSession(ctx context.Context, signature string) (err error)

+ func (r *RequestManager) Get(ctx context.Context, entityName string, requestID string) (result storage.Request, err error)

+ func (r *RequestManager) GetAccessTokenSession(ctx context.Context, signature string, session fosite.Session) (request fosite.Requester, err error)

+ func (r *RequestManager) GetAuthorizeCodeSession(ctx context.Context, code string, session fosite.Session) (request fosite.Requester, err error)

+ func (r *RequestManager) GetBySignature(ctx context.Context, entityName string, signature string) (result storage.Request, err error)

+ func (r *RequestManager) GetOpenIDConnectSession(ctx context.Context, authorizeCode string, requester fosite.Requester) (request fosite.Requester, err error)

+ func (r *RequestManager) GetPKCERequestSession(ctx context.Context, signature string, session fosite.Session) (request fosite.Requester, err error)

+ func (r *RequestManager) GetRefreshTokenSession(ctx context.Context, signature string, session fosite.Session) (request fosite.Requester, err error)

+ func (r *RequestManager) InvalidateAuthorizeCodeSession(ctx context.Context, code string) (err error)

+ func (r *RequestManager) List(ctx context.Context, entityName string, filter storage.ListRequestsRequest) (results []storage.Request, err error)

+ func (r *RequestManager) RevokeAccessToken(ctx context.Context, requestID string) (err error)

+ func (r *RequestManager) RevokeRefreshToken(ctx context.Context, requestID string) (err error)

+ func (r *RequestManager) Update(ctx context.Context, entityName string, requestID string, ...) (result storage.Request, err error)

+ type Store struct

+ DB *DB

+ Hasher fosite.Hasher

+ func New(cfg *Config, hashee fosite.Hasher) (*Store, error)

+ func NewDefaultStore() (*Store, error)

+ func (s *Store) Close()

+ func (s *Store) NewSession(ctx context.Context) (context.Context, func(), error)

+ type UserManager struct

+ DB *DB

+ Hasher fosite.Hasher

+ func (u *UserManager) Authenticate(ctx context.Context, username string, password string) (result storage.User, err error)

+ func (u *UserManager) AuthenticateByID(ctx context.Context, userID string, password string) (result storage.User, err error)

+ func (u *UserManager) AuthenticateByUsername(ctx context.Context, username string, password string) (result storage.User, err error)

+ func (u *UserManager) AuthenticateMigration(ctx context.Context, currentAuth storage.AuthUserFunc, userID string, ...) (result storage.User, err error)

+ func (u *UserManager) Configure(ctx context.Context) (err error)

+ func (u *UserManager) Create(ctx context.Context, user storage.User) (result storage.User, err error)

+ func (u *UserManager) Delete(ctx context.Context, userID string) (err error)

+ func (u *UserManager) Get(ctx context.Context, userID string) (result storage.User, err error)

+ func (u *UserManager) GetByUsername(ctx context.Context, username string) (result storage.User, err error)

+ func (u *UserManager) GrantScopes(ctx context.Context, userID string, scopes []string) (result storage.User, err error)

+ func (u *UserManager) List(ctx context.Context, filter storage.ListUsersRequest) (results []storage.User, err error)

+ func (u *UserManager) Migrate(ctx context.Context, migratedUser storage.User) (result storage.User, err error)

+ func (u *UserManager) RemoveScopes(ctx context.Context, userID string, scopes []string) (result storage.User, err error)

+ func (u *UserManager) Update(ctx context.Context, userID string, updatedUser storage.User) (result storage.User, err error)