service

Documentation

Index

• Constants
• func LoadPrivateKey(path urischeme.URIScheme) (interface{}, error)
• func NewHTTP(requestHandler *RequestHandler, logger log.Logger) http.Handler
• type APIsConfig
  • func (c *APIsConfig) Validate() error
• type AccessTokenType
• type AllowedGrantType
• type AsymmetricKey
• type Client
  • func (c *Client) Validate() error
• type ClientsConfig
  • func (c *ClientsConfig) Validate() error
• type Config
  • func (c Config) String() string
  • func (c *Config) Validate() error
• type HTTPConfig
  • func (c *HTTPConfig) Validate() error
• type OAuthClientsConfig
  • func (c OAuthClientsConfig) Find(id string) *Client
• type OAuthSignerConfig
  • func (c *OAuthSignerConfig) Validate() error
• type RequestHandler
  • func NewRequestHandler(ctx context.Context, config *Config, idTokenKey *rsa.PrivateKey, ...) (*RequestHandler, error)
• type Service
  • func New(ctx context.Context, config Config, fileWatcher *fsnotify.Watcher, ...) (*Service, error)
  • func (s *Service) Close() error
  • func (s *Service) Serve() error

Constants

const (
	DeviceUserID = "1"
	DefaultScope = "openid profile email offline_access r:* w:*"
)

const (
	TokenScopeKey    = "scope"
	TokenNicknameKey = "nickname"
	TokenNameKey     = "name"
	TokenPictureKey  = "picture"
)

Functions

func LoadPrivateKey

func LoadPrivateKey(path urischeme.URIScheme) (interface{}, error)

func NewHTTP

func NewHTTP(requestHandler *RequestHandler, logger log.Logger) http.Handler

NewHTTP returns HTTP handler

Types

type APIsConfig

type APIsConfig struct {
	HTTP HTTPConfig `yaml:"http" json:"http"`
}

Config represent application configuration

func (*APIsConfig) Validate

func (c *APIsConfig) Validate() error

type AccessTokenType

type AccessTokenType string

const AccessTokenType_JWT AccessTokenType = "jwt"

type AllowedGrantType

type AllowedGrantType string

const (
	AllowedGrantType_AUTHORIZATION_CODE AllowedGrantType = "authorization_code"
	AllowedGrantType_CLIENT_CREDENTIALS AllowedGrantType = "client_credentials"
	AllowedGrantType_PASSWORD           AllowedGrantType = "password"
	AllowedGrantType_REFRESH_TOKEN      AllowedGrantType = "refresh_token"
)

type AsymmetricKey

type AsymmetricKey struct {
	PrivateFile string
	PublicFile  string
}

type Client

type Client struct {
	ID                              string        `yaml:"id"`
	ClientSecret                    string        `yaml:"secret"`
	AuthorizationCodeLifetime       time.Duration `yaml:"authorizationCodeLifetime"`
	AccessTokenLifetime             time.Duration `yaml:"accessTokenLifetime"`
	CodeRestrictionLifetime         time.Duration `yaml:"codeRestrictionLifetime"`
	RefreshTokenRestrictionLifetime time.Duration `yaml:"refreshTokenRestrictionLifetime"`
	ConsentScreenEnabled            bool          `yaml:"consentScreenEnabled"`
	RequireIssuedAuthorizationCode  bool          `yaml:"requireIssuedAuthorizationCode"`
	RequiredScope                   []string      `yaml:"requiredScope"`
	RequiredResponseType            string        `yaml:"requiredResponseType"`
	RequiredRedirectURI             string        `yaml:"requiredRedirectURI"`
}

func (*Client) Validate

func (c *Client) Validate() error

type ClientsConfig

type ClientsConfig struct {
	OpenTelemetryCollector http.OpenTelemetryCollectorConfig `yaml:"openTelemetryCollector" json:"openTelemetryCollector"`
}

func (*ClientsConfig) Validate

func (c *ClientsConfig) Validate() error

type Config

type Config struct {
	Log         log.Config        `yaml:"log" json:"log"`
	APIs        APIsConfig        `yaml:"apis" json:"apis"`
	Clients     ClientsConfig     `yaml:"clients" json:"clients"`
	OAuthSigner OAuthSignerConfig `yaml:"oauthSigner" json:"oauthSigner"`
}

Config represents application configuration

func (Config) String

func (c Config) String() string

func (*Config) Validate

func (c *Config) Validate() error

type HTTPConfig

type HTTPConfig struct {
	Connection listener.Config `yaml:",inline" json:",inline"`
	Server     server.Config   `yaml:",inline" json:",inline"`
}

func (*HTTPConfig) Validate

func (c *HTTPConfig) Validate() error

type OAuthClientsConfig

type OAuthClientsConfig []*Client

func (OAuthClientsConfig) Find

func (c OAuthClientsConfig) Find(id string) *Client

type OAuthSignerConfig

type OAuthSignerConfig struct {
	IDTokenKeyFile     urischeme.URIScheme `yaml:"idTokenKeyFile" json:"idTokenKeyFile"`
	AccessTokenKeyFile urischeme.URIScheme `yaml:"accessTokenKeyFile" json:"accessTokenKeyFile"`
	Domain             string              `yaml:"domain" json:"domain"`
	Clients            OAuthClientsConfig  `yaml:"clients" json:"clients"`
}

func (*OAuthSignerConfig) Validate

func (c *OAuthSignerConfig) Validate() error

type RequestHandler

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

RequestHandler for handling incoming request

func NewRequestHandler

func NewRequestHandler(ctx context.Context, config *Config, idTokenKey *rsa.PrivateKey, accessTokenKey interface{}) (*RequestHandler, error)

NewRequestHandler factory for new RequestHandler

type Service

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

Server handle HTTP request

func New

func New(ctx context.Context, config Config, fileWatcher *fsnotify.Watcher, logger log.Logger) (*Service, error)

New parses configuration and creates new Server with provided store and bus

func (*Service) Close

func (s *Service) Close() error

Shutdown ends serving

func (*Service) Serve

func (s *Service) Serve() error

Serve starts the service's HTTP server and blocks