Documentation ¶
Overview ¶
Package flame implements an authenticator that provides OAuth2 compatible authentication with JWT tokens.
Index ¶
- Constants
- Variables
- func AddAccessTokenIndexes(i *coal.Indexer, autoExpire bool)
- func AddApplicationIndexes(i *coal.Indexer)
- func AddRefreshTokenIndexes(i *coal.Indexer, autoExpire bool)
- func AddUserIndexes(i *coal.Indexer)
- func Callback(scope string) *fire.Callback
- func DefaultGrantStrategy(scope oauth2.Scope, _ Client, _ ResourceOwner) (oauth2.Scope, error)
- func DefaultTokenData(_ Client, ro ResourceOwner, _ Token) map[string]interface{}
- func EnsureApplication(store *coal.Store, name, key, secret string) (string, error)
- func EnsureFirstUser(store *coal.Store, name, email, password string) error
- func TokenMigrator(remove bool) func(http.Handler) http.Handler
- type AccessToken
- type Application
- type Authenticator
- type Client
- type Policy
- type RefreshToken
- type ResourceOwner
- type ResourceOwnerDescription
- type Token
- type TokenClaims
- type User
Constants ¶
const ( // AccessTokenContextKey is the key used to save the access token in a context. AccessTokenContextKey = ctxKey("access-token") // ClientContextKey is the key used to save the client in a context. ClientContextKey = ctxKey("client") // ResourceOwnerContextKey is the key used to save the resource owner in a context. ResourceOwnerContextKey = ctxKey("resource-owner") )
Variables ¶
var ErrGrantRejected = errors.New("grant rejected")
ErrGrantRejected should be returned by the GrantStrategy to indicate a rejection of the grant based on the provided conditions.
var ErrInvalidFilter = errors.New("invalid filter")
ErrInvalidFilter should be returned by the Filter to indicate that the request includes invalid filter parameters.
var ErrInvalidScope = errors.New("invalid scope")
ErrInvalidScope should be returned by the GrantStrategy to indicate that the requested scope exceeds the grantable scope.
Functions ¶
func AddAccessTokenIndexes ¶ added in v0.8.8
AddAccessTokenIndexes will add access token indexes to the specified indexer.
func AddApplicationIndexes ¶ added in v0.8.8
AddApplicationIndexes will add application indexes to the specified indexer.
func AddRefreshTokenIndexes ¶ added in v0.8.8
AddRefreshTokenIndexes will add refresh token indexes to the specified indexer.
func AddUserIndexes ¶ added in v0.8.8
AddUserIndexes will add user indexes to the specified indexer.
func Callback ¶
Callback returns a callback that can be used to protect resources by requiring an access token with the provided scope to be granted.
Note: It requires that the request has already been authorized using the Authorizer middleware from a Authenticator.
func DefaultGrantStrategy ¶
DefaultGrantStrategy grants only empty scopes.
func DefaultTokenData ¶ added in v0.17.0
func DefaultTokenData(_ Client, ro ResourceOwner, _ Token) map[string]interface{}
DefaultTokenData adds the user's id to the token data claim.
func EnsureApplication ¶ added in v0.8.7
EnsureApplication will ensure that an application with the provided name exists and returns its key.
func EnsureFirstUser ¶ added in v0.8.7
EnsureFirstUser ensures the existence of a first user if no other has been created.
func TokenMigrator ¶
TokenMigrator is a middleware that detects access tokens passed via query parameters and migrates them to a Bearer Token header. Additionally it may remove the migrated query parameter from the request.
Note: The TokenMigrator should be added before any logger in the middleware chain to successfully protect the access token from being exposed.
Types ¶
type AccessToken ¶
type AccessToken struct { coal.Base `json:"-" bson:",inline" coal:"access-tokens:access_tokens"` ExpiresAt time.Time `json:"expires-at" bson:"expires_at"` Scope []string `json:"scope" bson:"scope"` Client bson.ObjectId `json:"client-id" bson:"client_id"` ResourceOwner *bson.ObjectId `json:"resource-owner-id" bson:"resource_owner_id"` }
AccessToken is the built-in model used to store access tokens.
func (*AccessToken) GetTokenData ¶
GetTokenData implements the flame.Token interface.
func (*AccessToken) SetTokenData ¶
func (t *AccessToken) SetTokenData(scope []string, expiresAt time.Time, client Client, resourceOwner ResourceOwner)
SetTokenData implements the flame.Token interface.
func (*AccessToken) Validate ¶ added in v0.15.0
func (t *AccessToken) Validate() error
Validate implements the fire.ValidatableModel interface.
type Application ¶
type Application struct { coal.Base `json:"-" bson:",inline" coal:"applications"` Name string `json:"name" bson:"name"` Key string `json:"key" bson:"key"` Secret string `json:"secret,omitempty" bson:"-"` SecretHash []byte `json:"-" bson:"secret"` RedirectURL string `json:"redirect-url" bson:"redirect_url"` }
Application is the built-in model used to store clients.
func (*Application) DescribeClient ¶
func (a *Application) DescribeClient() string
DescribeClient implements the flame.Client interface.
func (*Application) HashSecret ¶ added in v0.8.5
func (a *Application) HashSecret() error
HashSecret will hash Secret and set SecretHash.
func (*Application) ValidRedirectURL ¶ added in v0.8.7
func (a *Application) ValidRedirectURL(url string) bool
ValidRedirectURL implements the flame.Client interface.
func (*Application) ValidSecret ¶
func (a *Application) ValidSecret(secret string) bool
ValidSecret implements the flame.Client interface.
func (*Application) Validate ¶ added in v0.8.5
func (a *Application) Validate() error
Validate implements the coal.ValidatableModel interface.
type Authenticator ¶
type Authenticator struct { // The function gets invoked by the authenticator with critical errors. Reporter func(error) // contains filtered or unexported fields }
An Authenticator provides OAuth2 based authentication. The implementation currently supports the Resource Owner Credentials Grant, Client Credentials Grant and Implicit Grant.
func NewAuthenticator ¶
func NewAuthenticator(store *coal.Store, policy *Policy) *Authenticator
NewAuthenticator constructs a new Authenticator from a store and policy.
func (*Authenticator) Authorizer ¶
func (a *Authenticator) Authorizer(scope string, force, loadClient, loadResourceOwner bool) func(http.Handler) http.Handler
Authorizer returns a middleware that can be used to authorize a request by requiring an access token with the provided scope to be granted.
type Client ¶
type Client interface { coal.Model // DescribeClient should return a the clients identifier field. DescribeClient() (identifierField string) // ValidRedirectURL should return whether the specified redirect url can be // used by this client. // // Note: In order to increases security the callback should only allow // pre-registered redirect urls. ValidRedirectURL(string) bool // ValidSecret should determine whether the specified plain text secret // matches the stored hashed secret. ValidSecret(string) bool }
Client is the interface that must be implemented by clients.
type Policy ¶
type Policy struct { // The secret should be at least 16 characters long. Secret []byte // The available grants. PasswordGrant bool ClientCredentialsGrant bool ImplicitGrant bool // The token models. AccessToken Token RefreshToken Token // The client models. Clients []Client // ResourceOwners should return a list of resource owner models that are // tried in order to resolve grant requests. ResourceOwners func(Client) []ResourceOwner // Filter should return a filter that should be applied when looking up a // resource owner. This callback can be used to select resource owners // based on other request parameters. It can return ErrInvalidFilter to // cancel the authentication request. Filter func(ResourceOwner, *http.Request) (bson.M, error) // GrantStrategy is invoked by the authenticator with the grant type, the // requested scope, the client and the resource owner before issuing an // access token. The callback should return no error and the scope that // should be granted. It can return ErrGrantRejected or ErrInvalidScope to // cancel the grant request. // // Note: ResourceOwner is not set for a client credentials grant. GrantStrategy func(oauth2.Scope, Client, ResourceOwner) (oauth2.Scope, error) // TokenData should return a map of data that should be included in the JWT // tokens under the "dat" field. TokenData func(Client, ResourceOwner, Token) map[string]interface{} // The token used lifespans. AccessTokenLifespan time.Duration RefreshTokenLifespan time.Duration }
A Policy configures the provided authentication schemes.
func DefaultPolicy ¶
DefaultPolicy returns a simple policy that uses all built-in models and strategies.
Note: The secret should be at least 16 characters long.
func (*Policy) GenerateToken ¶
func (p *Policy) GenerateToken(id bson.ObjectId, issuedAt, expiresAt time.Time, client Client, resourceOwner ResourceOwner, token Token) (string, error)
GenerateToken returns a new token for the provided information.
func (*Policy) ParseToken ¶
func (p *Policy) ParseToken(str string) (*TokenClaims, bool, error)
ParseToken will parse the presented token and return its claims, if it is expired and eventual errors.
type RefreshToken ¶
type RefreshToken struct { coal.Base `json:"-" bson:",inline" coal:"refresh-tokens:refresh_tokens"` ExpiresAt time.Time `json:"expires-at" bson:"expires_at"` Scope []string `json:"scope" bson:"scope"` Client bson.ObjectId `json:"client-id" bson:"client_id"` ResourceOwner *bson.ObjectId `json:"resource-owner-id" bson:"resource_owner_id"` }
RefreshToken is the built-in model used to store refresh tokens.
func (*RefreshToken) GetTokenData ¶
GetTokenData implements the flame.Token interface.
func (*RefreshToken) SetTokenData ¶
func (t *RefreshToken) SetTokenData(scope []string, expiresAt time.Time, client Client, resourceOwner ResourceOwner)
SetTokenData implements the flame.Token interface.
func (*RefreshToken) Validate ¶ added in v0.15.0
func (t *RefreshToken) Validate() error
Validate implements the fire.ValidatableModel interface.
type ResourceOwner ¶
type ResourceOwner interface { coal.Model // DescribeResourceOwner should return the resource owners identifier field. DescribeResourceOwner() (identifierField string) // ValidSecret should determine whether the specified plain text password // matches the stored hashed password. ValidPassword(string) bool }
ResourceOwner is the interface that must be implemented resource owners.
type ResourceOwnerDescription ¶
type ResourceOwnerDescription struct {
IdentifierField string
}
A ResourceOwnerDescription is returned by a ResourceOwner model to specify details about its implementation.
type Token ¶
type Token interface { coal.Model // GetTokenData should collect and return the tokens data. GetTokenData() (scope []string, expiresAt time.Time, client bson.ObjectId, resourceOwner *bson.ObjectId) // SetTokenData should set the specified token data. SetTokenData(scope []string, expiresAt time.Time, client Client, resourceOwner ResourceOwner) }
Token is the interface that must be implemented by the tokens.
type TokenClaims ¶
type TokenClaims struct { jwt.StandardClaims // Data contains user defined key value pairs. Data map[string]interface{} `json:"dat"` }
TokenClaims represents the data included in an access token and refresh token.
type User ¶
type User struct { coal.Base `json:"-" bson:",inline" coal:"users"` Name string `json:"name" bson:"name"` Email string `json:"email" bson:"email"` Password string `json:"password,omitempty" bson:"-"` PasswordHash []byte `json:"-" bson:"password"` }
User is the built-in model used to store resource owners.
func (*User) DescribeResourceOwner ¶
DescribeResourceOwner implements the flame.ResourceOwner interface.
func (*User) HashPassword ¶ added in v0.8.5
HashPassword will hash Password and set PasswordHash.
func (*User) ValidPassword ¶
ValidPassword implements the flame.ResourceOwner interface.