service

Documentation

Index

• func CreateResourceContentToObserver(client *session, resourceChanged *events.ResourceChanged, observe uint32, ...) (*pool.Message, error)
• func DefaultCodeToLevel(code codes.Code, logger log.Logger) func(args ...interface{})
• func MakeGetConfigForClient(tlsCfg *tls.Config) tls.Config
• func New(ctx context.Context, config Config, fileWatcher *fsnotify.Watcher, ...) (*service.Service, error)
• func NewExchangeCache() *exchangeCache
• func NewRefreshCache() *refreshCache
• func ParsePublishedResources(data io.ReadSeeker, deviceID string) (wkRd, error)
• func PublishResourceLinks(ctx context.Context, raClient raService.ResourceAggregateClient, ...) ([]*commands.Resource, error)
• func ValidUntil(expiry time.Time) (validUntil int64, ok bool)
• func WantToLog(code codes.Code, logger log.Logger) bool
• type APIsConfig
  • func (c *APIsConfig) Validate() error
• type AuthorizationConfig
  • func (c *AuthorizationConfig) Validate() error
• type COAPConfig
  • func (c *COAPConfig) Validate() error
• type ClientsConfig
  • func (c *ClientsConfig) Validate() error
• type CoapRefreshTokenReq
• type CoapRefreshTokenResp
• type CoapSignInReq
• type CoapSignInResp
• type CoapSignUpRequest
• type CoapSignUpResponse
• type Config
  • func (c Config) String() string
  • func (c *Config) Validate() error
• type DeviceStatusExpirationConfig
  • func (c *DeviceStatusExpirationConfig) Validate() error
• type EventBusConfig
  • func (c *EventBusConfig) Validate() error
• type GrpcServerConfig
  • func (c *GrpcServerConfig) Validate() error
• type IdentityStoreConfig
  • func (c *IdentityStoreConfig) Validate() error
• type Interceptor
• type LogConfig
• type ProvidersConfig
  • func (c *ProvidersConfig) Validate(firstAuthority string, providerNames map[string]bool) error
• type ResourceAggregateConfig
  • func (c *ResourceAggregateConfig) Validate() error
• type Service
  • func (s *Service) ValidateToken(ctx context.Context, token string) (pkgJwt.Claims, error)
  • func (s *Service) VerifyDeviceID(tlsDeviceID string, claim pkgJwt.Claims) error

Functions

func CreateResourceContentToObserver

func CreateResourceContentToObserver(client *session, resourceChanged *events.ResourceChanged, observe uint32, token coapMessage.Token) (*pool.Message, error)

func DefaultCodeToLevel

func DefaultCodeToLevel(code codes.Code, logger log.Logger) func(args ...interface{})

DefaultCodeToLevel is the default implementation of gRPC return codes and interceptor log level for server side.

func MakeGetConfigForClient

func MakeGetConfigForClient(tlsCfg *tls.Config) tls.Config

func New

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

New creates server.

func NewExchangeCache

func NewExchangeCache() *exchangeCache

func NewRefreshCache

func NewRefreshCache() *refreshCache

func ParsePublishedResources

func ParsePublishedResources(data io.ReadSeeker, deviceID string) (wkRd, error)

func PublishResourceLinks

func PublishResourceLinks(ctx context.Context, raClient raService.ResourceAggregateClient, links schema.ResourceLinks, deviceID string, ttl int32, connectionID string, sequence uint64) ([]*commands.Resource, error)

func ValidUntil

func ValidUntil(expiry time.Time) (validUntil int64, ok bool)

ValidUntil returns time until expiration. No expiration is denoted by expiry = 0 for which 0 is returned. When expired, ok is false.

func WantToLog

func WantToLog(code codes.Code, logger log.Logger) bool

Types

type APIsConfig

type APIsConfig struct {
	COAP COAPConfig `yaml:"coap" json:"coap"`
}

func (*APIsConfig) Validate

func (c *APIsConfig) Validate() error

type AuthorizationConfig

type AuthorizationConfig struct {
	DeviceIDClaim string            `yaml:"deviceIDClaim" json:"deviceIdClaim"`
	OwnerClaim    string            `yaml:"ownerClaim" json:"ownerClaim"`
	Providers     []ProvidersConfig `yaml:"providers" json:"providers"`
}

func (*AuthorizationConfig) Validate

func (c *AuthorizationConfig) Validate() error

type COAPConfig

type COAPConfig struct {
	ExternalAddress            string              `yaml:"externalAddress" json:"externalAddress"`
	OwnerCacheExpiration       time.Duration       `yaml:"ownerCacheExpiration" json:"ownerCacheExpiration"`
	SubscriptionBufferSize     int                 `yaml:"subscriptionBufferSize" json:"subscriptionBufferSize"`
	Authorization              AuthorizationConfig `yaml:"authorization" json:"authorization"`
	RequireBatchObserveEnabled bool                `yaml:"requireBatchObserveEnabled" json:"requireBatchObserveEnabled"`
	coapService.Config         `yaml:",inline" json:",inline"`
}

func (*COAPConfig) Validate

func (c *COAPConfig) Validate() error

type ClientsConfig

type ClientsConfig struct {
	Eventbus               EventBusConfig          `yaml:"eventBus" json:"eventBus"`
	IdentityStore          IdentityStoreConfig     `yaml:"identityStore" json:"identityStore"`
	ResourceAggregate      ResourceAggregateConfig `yaml:"resourceAggregate" json:"resourceAggregate"`
	ResourceDirectory      GrpcServerConfig        `yaml:"resourceDirectory" json:"resourceDirectory"`
	OpenTelemetryCollector otelClient.Config       `yaml:"openTelemetryCollector" json:"openTelemetryCollector"`
}

func (*ClientsConfig) Validate

func (c *ClientsConfig) Validate() error

type CoapRefreshTokenReq

type CoapRefreshTokenReq struct {
	DeviceID     string `json:"di"`
	UserID       string `json:"uid"`
	RefreshToken string `json:"refreshtoken"`
}

type CoapRefreshTokenResp

type CoapRefreshTokenResp struct {
	ExpiresIn    int64  `json:"expiresin"`
	AccessToken  string `json:"accesstoken"`
	RefreshToken string `json:"refreshtoken"`
}

type CoapSignInReq

type CoapSignInReq struct {
	DeviceID    string `json:"di"`
	UserID      string `json:"uid"`
	AccessToken string `json:"accesstoken"`
	Login       bool   `json:"login"`
}

type CoapSignInResp

type CoapSignInResp struct {
	ExpiresIn int64 `json:"expiresin"`
}

type CoapSignUpRequest

type CoapSignUpRequest struct {
	DeviceID                string `json:"di"`
	AuthorizationCode       string `json:"accesstoken"`
	AuthorizationCodeLegacy string `json:"authcode"`
	AuthorizationProvider   string `json:"authprovider"`
}

type CoapSignUpResponse

type CoapSignUpResponse struct {
	AccessToken  string `json:"accesstoken"`
	UserID       string `json:"uid"`
	RefreshToken string `json:"refreshtoken"`
	ExpiresIn    int64  `json:"expiresin"`
	RedirectURI  string `json:"redirecturi"`
}

type Config

type Config struct {
	Log       LogConfig     `yaml:"log" json:"log"`
	APIs      APIsConfig    `yaml:"apis" json:"apis"`
	Clients   ClientsConfig `yaml:"clients" json:"clients"`
	TaskQueue queue.Config  `yaml:"taskQueue" json:"taskQueue"`
}

Config represent application configuration

func (Config) String

func (c Config) String() string

String return string representation of Config

func (*Config) Validate

func (c *Config) Validate() error

type DeviceStatusExpirationConfig

type DeviceStatusExpirationConfig struct {
	Enabled   bool          `yaml:"enabled" json:"enabled"`
	ExpiresIn time.Duration `yaml:"expiresIn" json:"expiresIn"`
}

func (*DeviceStatusExpirationConfig) Validate

func (c *DeviceStatusExpirationConfig) Validate() error

type EventBusConfig

type EventBusConfig struct {
	NATS natsClient.Config `yaml:"nats" json:"nats"`
}

func (*EventBusConfig) Validate

func (c *EventBusConfig) Validate() error

type GrpcServerConfig

type GrpcServerConfig struct {
	Connection client.Config `yaml:"grpc" json:"grpc"`
}

func (*GrpcServerConfig) Validate

func (c *GrpcServerConfig) Validate() error

type IdentityStoreConfig

type IdentityStoreConfig struct {
	Connection client.Config `yaml:"grpc" json:"grpc"`
}

func (*IdentityStoreConfig) Validate

func (c *IdentityStoreConfig) Validate() error

type Interceptor

type Interceptor = func(ctx context.Context, code codes.Code, path string) (context.Context, error)

type LogConfig

type LogConfig struct {
	DumpBody   bool `yaml:"dumpBody" json:"dumpBody"`
	log.Config `yaml:",inline"`
}

Config represent application configuration

type ProvidersConfig

type ProvidersConfig struct {
	Name          string `yaml:"name" json:"name"`
	oauth2.Config `yaml:",inline"`
}

func (*ProvidersConfig) Validate

func (c *ProvidersConfig) Validate(firstAuthority string, providerNames map[string]bool) error

type ResourceAggregateConfig

type ResourceAggregateConfig struct {
	Connection             client.Config                `yaml:"grpc" json:"grpc"`
	DeviceStatusExpiration DeviceStatusExpirationConfig `yaml:"deviceStatusExpiration" json:"deviceStatusExpiration"`
}

func (*ResourceAggregateConfig) Validate

func (c *ResourceAggregateConfig) Validate() error

type Service

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

Service is a configuration of coap-gateway

func (*Service) ValidateToken

func (s *Service) ValidateToken(ctx context.Context, token string) (pkgJwt.Claims, error)

func (*Service) VerifyDeviceID

func (s *Service) VerifyDeviceID(tlsDeviceID string, claim pkgJwt.Claims) error