providers

type BakedRule struct {
	Resources []glob.Glob
	System    SecSystem
	Get       bool
	Command   bool
	History   bool
}

type IAuthenticatedUser interface {
	Name() string
	DeviceGet(string) bool
	DeviceCommand(string) bool
	DeviceHistory(string) bool
	TriggerGet(string) bool
	TriggerHistory(string) bool
	Workers() bool
	Entities() bool
	Logs() bool
}

type IBusProvider interface {
	Subscribe(channel bus.ChannelName, queue chan bus.RawMessage) error
	SubscribeStr(channel string, queue chan bus.RawMessage) error
	SubscribeToWorker(workerName string, queue chan bus.RawMessage) error
	Unsubscribe(channel string)
	Publish(channel bus.ChannelName, messages ...interface{})
	PublishStr(channel string, messages ...interface{})
	PublishToWorker(workerName string, messages ...interface{})
	Ping() error
}

type ICronProvider interface {
	AddFunc(spec string, cmd func()) (int, error)
	RemoveFunc(id int)
}

type IExtendedAPIProvider interface {
	ILoadedProvider
	ID() string
	Routes() []string
}

type IGroupProvider interface {
	ID() string
	Devices() []string
	InvokeCommand(enums.Command, map[string]interface{})
}

type IInternalFanOutProvider interface {
	common.IFanOutProvider

	ChannelInDeviceUpdates() chan *common.MsgDeviceUpdate
	SubscribeTriggerUpdates() (int64, chan string)
	UnSubscribeTriggerUpdates(int64)
	ChannelInTriggerUpdates() chan string
}

type IInternalSecret interface {
	common.ISecretProvider
	UpdateLogger(pluginLogger common.ILoggerProvider)
}

type ILoadedProvider interface {
	Unload()
}

type ILocationProvider interface {
	ID() string
	Icon() string
	Devices() []string
}

type INotificationProvider interface {
	GetID() string
	Message(string)
}

type IPluginLoaderProvider interface {
	LoadPlugin(*PluginLoadRequest) (interface{}, error)
	UpdateLogger(common.ILoggerProvider)
}

type ISecurityProvider interface {
	GetUser(map[string][]string) (IAuthenticatedUser, error)
}

type IServerProvider interface {
	Start()
	InternalCommandInvokeDeviceCommand(glob.Glob, enums.Command, map[string]interface{})
	SendNotificationCommand(glob.Glob, string)
	GetDevice(string) *KnownDevice
	PushMasterDeviceUpdate(*MasterDeviceUpdate)
}

type ISettingsProvider interface {
	SystemLogger() common.ILoggerProvider
	PluginLogger() common.ILoggerProvider
	ServiceBus() IBusProvider
	NodeID() string
	Cron() ICronProvider
	PluginLoader() IPluginLoaderProvider
	Validator() IValidatorProvider
	WorkerSettings() *WorkerSettings
	MasterSettings() *MasterSettings
	IsWorker() bool
	DevicesConfig() []*RawDevice
	Secrets() common.ISecretProvider
	Security() ISecurityProvider
	Triggers() []*RawMasterComponent
	ExtendedAPIs() []*RawMasterComponent
	Notifications() []*RawMasterComponent
	Groups() []*RawMasterComponent
	FanOut() IInternalFanOutProvider
	Storage() IStorageProvider
	Timezone() *time.Location
}

type IStorageProvider interface {
	Heartbeat(string)
	State(*common.MsgDeviceUpdate)
	History(string) map[enums.Property]map[int64]interface{}
}

type ITriggerProvider interface {
	GetID() string
	GetLastTriggeredTime() int64
}

type IValidatorProvider interface {
	SetLogger(logger common.ILoggerProvider)
	Validate(interface{}) bool
}

type KnownDevice struct {
	Worker   string
	Type     enums.DeviceType
	Commands []string
}

type MasterDeviceUpdate struct {
	ID       string
	Name     string
	State    map[string]interface{}
	Commands []string
	Type     enums.DeviceType
}

type MasterSettings struct {
	Port         int                   `yaml:"port" validate:"required,port" default:"8000"`
	DelayedStart int                   `yaml:"delayedStart" validate:"gte=0"`
	UOM          enums.UOM             `yaml:"units" default:"imperial"`
	Timezone     string                `yaml:"timezone" default:"Local"`
	Locations    []*RawMasterComponent `yaml:"-"`
}

type PluginLoadRequest struct {
	SystemType         systems.SystemType
	PluginProvider     string
	RawConfig          []byte
	InitData           interface{}
	ExpectedType       reflect.Type
	DownloadTimeoutSec int
}

type RawDevice struct {
	Plugin     string
	DeviceType enums.DeviceType
	Selector   *RawDeviceSelector
	StrConfig  string
	Name       string
	IsAPI      bool
}

type RawDeviceSelector struct {
	Name      string            `yaml:"name"`
	Selectors map[string]string `yaml:"workerSelectors"`
}

type RawMasterComponent struct {
	Name      string
	Provider  string
	RawConfig []byte
}

type SecRole struct {
	Name  string        `yaml:"name" validate:"required"`
	Users []string      `yaml:"users" validate:"unique,min=1"`
	Rules []SecRoleRule `yaml:"rules" validate:"min=1"`
}

type SecRoleRule struct {
	System    string    `yaml:"system" validate:"required,oneof=* device core"`
	Resources []string  `yaml:"resources" validate:"unique,min=1"`
	Verbs     []SecVerb `yaml:"-"`
	StrVerb   []string  `yaml:"verbs" validate:"unique,min=1,oneof=* get command history"`
}

type SecSystem int

type SecVerb int

type WorkerSettings struct {
	Name       string            `yaml:"name"`
	Properties map[string]string `yaml:"properties"`
	MaxDevices int               `yaml:"maxDevices" validate:"gte=0,lte=1000" default:"99"`
	Timezone   string            `yaml:"timezone" default:"Local"`
}