sql

package
v2.2.0-pre.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 1, 2024 License: Apache-2.0 Imports: 45 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrTransactionOpen   = errors.New("There is already a transaction in this context.")
	ErrNoTransactionOpen = errors.New("There is no transaction in this context.")
)
View Source 
var Migrations embed.FS

Functions

func SignatureHash 

func SignatureHash(signature string) string

SignatureHash hashes the signature to prevent errors where the signature is longer than 128 characters (and thus doesn't fit into the pk).

Types

type Dependencies 

type Dependencies interface {
	ClientHasher() fosite.Hasher
	KeyCipher() *aead.AESGCM
	FlowCipher() *aead.XChaCha20Poly1305
	Kratos() kratos.Client
	contextx.Provider
	x.RegistryLogger
	x.TracingProvider
}

type OAuth2RequestSQL 

type OAuth2RequestSQL struct {
	ID                string         `db:"signature"`
	NID               uuid.UUID      `db:"nid"`
	Request           string         `db:"request_id"`
	ConsentChallenge  sql.NullString `db:"challenge_id"`
	RequestedAt       time.Time      `db:"requested_at"`
	Client            string         `db:"client_id"`
	Scopes            string         `db:"scope"`
	GrantedScope      string         `db:"granted_scope"`
	RequestedAudience string         `db:"requested_audience"`
	GrantedAudience   string         `db:"granted_audience"`
	Form              string         `db:"form_data"`
	Subject           string         `db:"subject"`
	Active            bool           `db:"active"`
	Session           []byte         `db:"session_data"`
	Table             tableName      `db:"-"`
}

func (OAuth2RequestSQL) TableName 

func (r OAuth2RequestSQL) TableName() string

type OldMigrationRecord 

type OldMigrationRecord struct {
	ID        string    `db:"id"`
	AppliedAt time.Time `db:"applied_at"`
}

this type is copied from sql-migrate to remove the dependency

type Persister 

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

func NewPersister 

func NewPersister(ctx context.Context, c *pop.Connection, r Dependencies, config *config.DefaultProvider, extraMigrations []fs.FS, goMigrations []popx.Migration) (*Persister, error)

func (*Persister) AcceptLogoutRequest 

func (p *Persister) AcceptLogoutRequest(ctx context.Context, challenge string) (*flow.LogoutRequest, error)

func (*Persister) AddKey 

func (p *Persister) AddKey(ctx context.Context, set string, key *jose.JSONWebKey) error

func (*Persister) AddKeySet 

func (p *Persister) AddKeySet(ctx context.Context, set string, keys *jose.JSONWebKeySet) error

func (*Persister) Authenticate 

func (p *Persister) Authenticate(ctx context.Context, name, secret string) error

func (*Persister) AuthenticateClient added in v2.2.0 

func (p *Persister) AuthenticateClient(ctx context.Context, id string, secret []byte) (_ *client.Client, err error)

func (*Persister) BeginTX 

func (p *Persister) BeginTX(ctx context.Context) (_ context.Context, err error)

func (*Persister) ClientAssertionJWTValid 

func (p *Persister) ClientAssertionJWTValid(ctx context.Context, jti string) (err error)

func (*Persister) Commit 

func (p *Persister) Commit(ctx context.Context) (err error)

func (*Persister) ConfirmLoginSession 

func (p *Persister) ConfirmLoginSession(ctx context.Context, loginSession *flow.LoginSession) error

ConfirmLoginSession creates or updates the login session. The NID will be set to the network ID of the context.

func (*Persister) Connection 

func (p *Persister) Connection(ctx context.Context) *pop.Connection

func (*Persister) CountClients 

func (p *Persister) CountClients(ctx context.Context) (n int, err error)

func (*Persister) CountGrants 

func (p *Persister) CountGrants(ctx context.Context) (n int, err error)

func (*Persister) CountSubjectsGrantedConsentRequests 

func (p *Persister) CountSubjectsGrantedConsentRequests(ctx context.Context, subject string) (int, error)

func (*Persister) CreateAccessTokenSession 

func (p *Persister) CreateAccessTokenSession(ctx context.Context, signature string, requester fosite.Requester) (err error)

func (*Persister) CreateAuthorizeCodeSession 

func (p *Persister) CreateAuthorizeCodeSession(ctx context.Context, signature string, requester fosite.Requester) error

func (*Persister) CreateClient 

func (p *Persister) CreateClient(ctx context.Context, c *client.Client) (err error)

func (*Persister) CreateConsentRequest 

func (p *Persister) CreateConsentRequest(ctx context.Context, f *flow.Flow, req *flow.OAuth2ConsentRequest) error

CreateConsentRequest configures fields that are introduced or changed in the consent request. It doesn't touch fields that would be copied from the login request.

func (*Persister) CreateForcedObfuscatedLoginSession 

func (p *Persister) CreateForcedObfuscatedLoginSession(ctx context.Context, session *consent.ForcedObfuscatedLoginSession) error

func (*Persister) CreateGrant 

func (p *Persister) CreateGrant(ctx context.Context, g trust.Grant, publicKey jose.JSONWebKey) (err error)

func (*Persister) CreateLoginRequest 

func (p *Persister) CreateLoginRequest(ctx context.Context, req *flow.LoginRequest) (*flow.Flow, error)

func (*Persister) CreateLoginSession 

func (p *Persister) CreateLoginSession(ctx context.Context, session *flow.LoginSession) error

func (*Persister) CreateLogoutRequest 

func (p *Persister) CreateLogoutRequest(ctx context.Context, request *flow.LogoutRequest) error

func (*Persister) CreateOpenIDConnectSession 

func (p *Persister) CreateOpenIDConnectSession(ctx context.Context, signature string, requester fosite.Requester) (err error)

func (*Persister) CreatePKCERequestSession 

func (p *Persister) CreatePKCERequestSession(ctx context.Context, signature string, requester fosite.Requester) (err error)

func (*Persister) CreateRefreshTokenSession 

func (p *Persister) CreateRefreshTokenSession(ctx context.Context, signature string, requester fosite.Requester) (err error)

func (*Persister) CreateWithNetwork 

func (p *Persister) CreateWithNetwork(ctx context.Context, v interface{}) error

func (*Persister) DeleteAccessTokenSession 

func (p *Persister) DeleteAccessTokenSession(ctx context.Context, signature string) (err error)

func (*Persister) DeleteAccessTokens 

func (p *Persister) DeleteAccessTokens(ctx context.Context, clientID string) (err error)

func (*Persister) DeleteClient 

func (p *Persister) DeleteClient(ctx context.Context, id string) (err error)

func (*Persister) DeleteGrant 

func (p *Persister) DeleteGrant(ctx context.Context, id string) (err error)

func (*Persister) DeleteKey 

func (p *Persister) DeleteKey(ctx context.Context, set, kid string) error

func (*Persister) DeleteKeySet 

func (p *Persister) DeleteKeySet(ctx context.Context, set string) error

func (*Persister) DeleteLoginSession 

func (p *Persister) DeleteLoginSession(ctx context.Context, id string) (deletedSession *flow.LoginSession, err error)

func (*Persister) DeleteOpenIDConnectSession 

func (p *Persister) DeleteOpenIDConnectSession(ctx context.Context, signature string) (err error)

func (*Persister) DeletePKCERequestSession 

func (p *Persister) DeletePKCERequestSession(ctx context.Context, signature string) (err error)

func (*Persister) DeleteRefreshTokenSession 

func (p *Persister) DeleteRefreshTokenSession(ctx context.Context, signature string) (err error)

func (*Persister) DetermineNetwork 

func (p *Persister) DetermineNetwork(ctx context.Context) (*networkx.Network, error)

func (*Persister) FindGrantedAndRememberedConsentRequests 

func (p *Persister) FindGrantedAndRememberedConsentRequests(ctx context.Context, client, subject string) (rs []flow.AcceptOAuth2ConsentRequest, err error)

func (*Persister) FindSubjectsGrantedConsentRequests 

func (p *Persister) FindSubjectsGrantedConsentRequests(ctx context.Context, subject string, limit, offset int) ([]flow.AcceptOAuth2ConsentRequest, error)

func (*Persister) FindSubjectsSessionGrantedConsentRequests 

func (p *Persister) FindSubjectsSessionGrantedConsentRequests(ctx context.Context, subject, sid string, limit, offset int) ([]flow.AcceptOAuth2ConsentRequest, error)

func (*Persister) FlushInactiveAccessTokens 

func (p *Persister) FlushInactiveAccessTokens(ctx context.Context, notAfter time.Time, limit int, batchSize int) (err error)

func (*Persister) FlushInactiveGrants 

func (p *Persister) FlushInactiveGrants(ctx context.Context, notAfter time.Time, _ int, _ int) (err error)

func (*Persister) FlushInactiveLoginConsentRequests 

func (p *Persister) FlushInactiveLoginConsentRequests(ctx context.Context, notAfter time.Time, limit int, batchSize int) error

func (*Persister) FlushInactiveRefreshTokens 

func (p *Persister) FlushInactiveRefreshTokens(ctx context.Context, notAfter time.Time, limit int, batchSize int) (err error)

func (*Persister) GenerateAndPersistKeySet 

func (p *Persister) GenerateAndPersistKeySet(ctx context.Context, set, kid, alg, use string) (*jose.JSONWebKeySet, error)

func (*Persister) GetAccessTokenSession 

func (p *Persister) GetAccessTokenSession(ctx context.Context, signature string, session fosite.Session) (request fosite.Requester, err error)

func (*Persister) GetAuthorizeCodeSession 

func (p *Persister) GetAuthorizeCodeSession(ctx context.Context, signature string, session fosite.Session) (request fosite.Requester, err error)

func (*Persister) GetClient 

func (p *Persister) GetClient(ctx context.Context, id string) (fosite.Client, error)

func (*Persister) GetClientAssertionJWT 

func (p *Persister) GetClientAssertionJWT(ctx context.Context, j string) (_ *oauth2.BlacklistedJTI, err error)

func (*Persister) GetClients 

func (p *Persister) GetClients(ctx context.Context, filters client.Filter) (_ []client.Client, err error)

func (*Persister) GetConcreteClient 

func (p *Persister) GetConcreteClient(ctx context.Context, id string) (c *client.Client, err error)

func (*Persister) GetConcreteGrant 

func (p *Persister) GetConcreteGrant(ctx context.Context, id string) (_ trust.Grant, err error)

func (*Persister) GetConsentRequest 

func (p *Persister) GetConsentRequest(ctx context.Context, challenge string) (*flow.OAuth2ConsentRequest, error)

func (*Persister) GetFlow 

func (p *Persister) GetFlow(ctx context.Context, loginChallenge string) (*flow.Flow, error)

func (*Persister) GetFlowByConsentChallenge 

func (p *Persister) GetFlowByConsentChallenge(ctx context.Context, challenge string) (*flow.Flow, error)

func (*Persister) GetForcedObfuscatedLoginSession 

func (p *Persister) GetForcedObfuscatedLoginSession(ctx context.Context, client, obfuscated string) (*consent.ForcedObfuscatedLoginSession, error)

func (*Persister) GetGrants 

func (p *Persister) GetGrants(ctx context.Context, limit, offset int, optionalIssuer string) (_ []trust.Grant, err error)

func (*Persister) GetKey 

func (p *Persister) GetKey(ctx context.Context, set, kid string) (*jose.JSONWebKeySet, error)

func (*Persister) GetKeySet 

func (p *Persister) GetKeySet(ctx context.Context, set string) (keys *jose.JSONWebKeySet, err error)

func (*Persister) GetLoginRequest 

func (p *Persister) GetLoginRequest(ctx context.Context, loginChallenge string) (*flow.LoginRequest, error)

func (*Persister) GetLogoutRequest 

func (p *Persister) GetLogoutRequest(ctx context.Context, challenge string) (*flow.LogoutRequest, error)

func (*Persister) GetOpenIDConnectSession 

func (p *Persister) GetOpenIDConnectSession(ctx context.Context, signature string, requester fosite.Requester) (_ fosite.Requester, err error)

func (*Persister) GetPKCERequestSession 

func (p *Persister) GetPKCERequestSession(ctx context.Context, signature string, session fosite.Session) (_ fosite.Requester, err error)

func (*Persister) GetPublicKey 

func (p *Persister) GetPublicKey(ctx context.Context, issuer string, subject string, keyId string) (_ *jose.JSONWebKey, err error)

func (*Persister) GetPublicKeyScopes 

func (p *Persister) GetPublicKeyScopes(ctx context.Context, issuer string, subject string, keyId string) (_ []string, err error)

func (*Persister) GetPublicKeys 

func (p *Persister) GetPublicKeys(ctx context.Context, issuer string, subject string) (_ *jose.JSONWebKeySet, err error)

func (*Persister) GetRefreshTokenSession 

func (p *Persister) GetRefreshTokenSession(ctx context.Context, signature string, session fosite.Session) (request fosite.Requester, err error)

func (*Persister) GetRememberedLoginSession 

func (p *Persister) GetRememberedLoginSession(ctx context.Context, loginSessionFromCookie *flow.LoginSession, id string) (*flow.LoginSession, error)

func (*Persister) HandleConsentRequest 

func (p *Persister) HandleConsentRequest(ctx context.Context, f *flow.Flow, r *flow.AcceptOAuth2ConsentRequest) (*flow.OAuth2ConsentRequest, error)

func (*Persister) HandleLoginRequest 

func (p *Persister) HandleLoginRequest(ctx context.Context, f *flow.Flow, challenge string, r *flow.HandledLoginRequest) (lr *flow.LoginRequest, err error)

func (*Persister) InvalidateAuthorizeCodeSession 

func (p *Persister) InvalidateAuthorizeCodeSession(ctx context.Context, signature string) (err error)

func (*Persister) IsJWTUsed 

func (p *Persister) IsJWTUsed(ctx context.Context, jti string) (ok bool, err error)

func (*Persister) IsNonceValid added in v2.2.0 

func (p *Persister) IsNonceValid(ctx context.Context, accessToken, nonce string) (err error)

func (*Persister) ListUserAuthenticatedClientsWithBackChannelLogout 

func (p *Persister) ListUserAuthenticatedClientsWithBackChannelLogout(ctx context.Context, subject, sid string) ([]client.Client, error)

func (*Persister) ListUserAuthenticatedClientsWithFrontChannelLogout 

func (p *Persister) ListUserAuthenticatedClientsWithFrontChannelLogout(ctx context.Context, subject, sid string) ([]client.Client, error)

func (*Persister) MarkJWTUsedForTime 

func (p *Persister) MarkJWTUsedForTime(ctx context.Context, jti string, exp time.Time) (err error)

func (*Persister) MigrateDown 

func (p *Persister) MigrateDown(ctx context.Context, steps int) error

func (*Persister) MigrateUp 

func (p *Persister) MigrateUp(ctx context.Context) error

func (*Persister) MigrateUpTo 

func (p *Persister) MigrateUpTo(ctx context.Context, steps int) (int, error)

func (*Persister) MigrationStatus 

func (p *Persister) MigrationStatus(ctx context.Context) (popx.MigrationStatuses, error)

func (*Persister) NetworkID 

func (p *Persister) NetworkID(ctx context.Context) uuid.UUID

func (*Persister) NewNonce added in v2.2.0 

func (p *Persister) NewNonce(ctx context.Context, accessToken string, expiresIn time.Time) (res string, err error)

func (*Persister) Ping 

func (p *Persister) Ping() error

func (*Persister) PrepareMigration 

func (p *Persister) PrepareMigration(_ context.Context) error

func (*Persister) QueryWithNetwork 

func (p *Persister) QueryWithNetwork(ctx context.Context) *pop.Query

func (*Persister) RejectLogoutRequest 

func (p *Persister) RejectLogoutRequest(ctx context.Context, challenge string) error

func (*Persister) RevokeAccessToken 

func (p *Persister) RevokeAccessToken(ctx context.Context, id string) (err error)

func (*Persister) RevokeRefreshToken 

func (p *Persister) RevokeRefreshToken(ctx context.Context, id string) (err error)

func (*Persister) RevokeRefreshTokenMaybeGracePeriod 

func (p *Persister) RevokeRefreshTokenMaybeGracePeriod(ctx context.Context, id string, _ string) (err error)

func (*Persister) RevokeSubjectClientConsentSession 

func (p *Persister) RevokeSubjectClientConsentSession(ctx context.Context, user, client string) error

func (*Persister) RevokeSubjectConsentSession 

func (p *Persister) RevokeSubjectConsentSession(ctx context.Context, user string) error

func (*Persister) RevokeSubjectLoginSession 

func (p *Persister) RevokeSubjectLoginSession(ctx context.Context, subject string) error

func (*Persister) Rollback 

func (p *Persister) Rollback(ctx context.Context) (err error)

func (*Persister) SetClientAssertionJWT 

func (p *Persister) SetClientAssertionJWT(ctx context.Context, jti string, exp time.Time) (err error)

func (*Persister) SetClientAssertionJWTRaw 

func (p *Persister) SetClientAssertionJWTRaw(ctx context.Context, jti *oauth2.BlacklistedJTI) (err error)

func (*Persister) UpdateClient 

func (p *Persister) UpdateClient(ctx context.Context, cl *client.Client) (err error)

func (*Persister) UpdateKey 

func (p *Persister) UpdateKey(ctx context.Context, set string, key *jose.JSONWebKey) error

UpdateKey updates or creates the key.

func (*Persister) UpdateKeySet 

func (p *Persister) UpdateKeySet(ctx context.Context, set string, keySet *jose.JSONWebKeySet) error

UpdateKeySet updates or creates the key set.

func (*Persister) UpdateWithNetwork 

func (p *Persister) UpdateWithNetwork(ctx context.Context, v interface{}) (int64, error)

func (*Persister) VerifyAndInvalidateConsentRequest 

func (p *Persister) VerifyAndInvalidateConsentRequest(ctx context.Context, verifier string) (*flow.AcceptOAuth2ConsentRequest, error)

func (*Persister) VerifyAndInvalidateLoginRequest 

func (p *Persister) VerifyAndInvalidateLoginRequest(ctx context.Context, verifier string) (*flow.HandledLoginRequest, error)

func (*Persister) VerifyAndInvalidateLogoutRequest 

func (p *Persister) VerifyAndInvalidateLogoutRequest(ctx context.Context, verifier string) (*flow.LogoutRequest, error)

func (Persister) WithFallbackNetworkID 

func (p Persister) WithFallbackNetworkID(nid uuid.UUID) persistence.Persister

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.