store

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 `bson:"_id"`
	LinkedCloudID string `bson:"linkedcloudid"`
	UserID        string
	Data          LinkedAccountData
}

type LinkedAccountData struct {
	OriginCloud oauth2.Token
	TargetCloud oauth2.Token
	State       LinkedAccountDataFlags
}

type LinkedAccountDataFlags uint8

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"`
	SupportedSubscriptionEvents 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

	Close(ctx context.Context) error
}