store

type AccessToken string

type Endpoint struct {
	URL                string   `json:"URL"`
	RootCAs            []string `json:"RootCAs"`
	InsecureSkipVerify bool     `json:"InsecureSkipVerify"`
	UseSystemCAs       bool     `json:"UseSystemCAs"`
}

type Events struct {
	Devices            []events.EventType `json:"Devices"`
	Device             []events.EventType `json:"Device"`
	Resource           []events.EventType `json:"Resource"`
	StaticDeviceEvents bool               `json:"StaticDeviceEvents"`
}

type LinkedAccount struct {
	ID            string `json:"Id" bson:"_id"`
	LinkedCloudID string `bson:"linkedcloudid"`
	UserID        string
	TargetCloud   Token
}

type LinkedAccountHandler interface {
	Handle(ctx context.Context, iter LinkedAccountIter) (err error)
}

type LinkedAccountIter interface {
	Next(ctx context.Context, sub *LinkedAccount) bool
	Err() error
}

type LinkedCloud struct {
	ID                           string       `json:"Id" bson:"_id"`
	Name                         string       `json:"Name"`
	OAuth                        oauth.Config `json:"OAuth"`
	SupportedSubscriptionsEvents Events       `json:"SupportedSubscriptionEvents"`
	Endpoint                     Endpoint     `json:"Endpoint"`
}

type LinkedCloudHandler interface {
	Handle(ctx context.Context, iter LinkedCloudIter) (err error)
}

type LinkedCloudIter interface {
	Next(ctx context.Context, sub *LinkedCloud) bool
	Err() error
}

type LinkedCloudsHandler struct {
	LinkedClouds []LinkedCloud
}

type Query struct {
	ID            string
	LinkedCloudID string
}

type Store interface {
	UpdateLinkedCloud(ctx context.Context, sub LinkedCloud) error
	InsertLinkedCloud(ctx context.Context, sub LinkedCloud) error
	RemoveLinkedCloud(ctx context.Context, ConfigId string) error
	LoadLinkedClouds(ctx context.Context, query Query, h LinkedCloudHandler) error

	UpdateLinkedAccount(ctx context.Context, sub LinkedAccount) error
	InsertLinkedAccount(ctx context.Context, sub LinkedAccount) error
	RemoveLinkedAccount(ctx context.Context, LinkedAccountId string) error
	LoadLinkedAccounts(ctx context.Context, query Query, h LinkedAccountHandler) error
}

type Token struct {
	AccessToken  AccessToken
	RefreshToken string
	Expiry       time.Time
}