deviceCore

type Broadcast struct {
	ID          string
	ElementType CoreType
	Parent      string
	Topic       string
	Level       string
	Value       string
	Received    time.Time
}

type CoreService interface {
	AllNetworks() SiteNetworks
	PrivateSiteNetworks() *SiteNetworks
	NetworkDevices(networkName string) (map[string]Device, error)
	NetworkByName(networkName string) Network
	DeviceByName(deviceName, networkName string) (Device, error)
	DeviceByID(deviceID string, networkName string) (Device, error)
	RemoveDeviceByID(deviceID string, networkName string) error

	PublishNetworkMessage(dm DeviceMessage)

	AllSchedules() []Schedule
	CreateSchedule(networkName string, deviceID string, transport OTATransport, firmwareID EID) (string, error)
	RemoveSchedule(scheduleID string) error
	ScheduleByID(scheduleID string) Schedule
	ScheduleByDeviceID(deviceID string) *Schedule

	AllFirmwares() []Firmware
	CreateFirmware(srcFile, dstFile string) (EID, error)
	RemoveFirmwareByID(firmwareID EID)
	FirmwareByID(firmwareID EID) (Firmware, error)
	FirmwareByName(firmwareName string) (Firmware, error)

	AllBroadcasts() []Broadcast
	RemoveBroadcastByID(broadcastID string)
	BroadcastByID(broadcastID string) (Broadcast, error)
}

type CoreType int

type Device struct {
	ID          string
	Title       string
	ElementType CoreType
	OTAEnabled  bool
	Parent      string
	Name        string
	Attrs       map[string]DeviceAttribute
	Nodes       map[string]DeviceNode
}

type DeviceAttribute struct {
	ID          EID
	ElementType CoreType
	Parent      string
	Name        string
	Value       string
	Props       map[string]DeviceAttributeProperty
}

type DeviceAttributeProperty struct {
	ID          EID
	ElementType CoreType
	Parent      string
	Name        string
	Value       string
	Props       map[string]DeviceAttributePropertyProperty
}

type DeviceAttributePropertyProperty struct {
	ID          EID
	ElementType CoreType
	Parent      string
	Name        string
	Value       string
}

type DeviceEventIntf interface {
	String() string
	Schedulable() bool
	Settable() bool
	OTAPublishMessage() bool
	OTAStatus() bool
	OTAActive() bool
	OTACurrent() bool
	OTARejected() bool
	OTAAborted() bool
	OTAFlashError() bool
	OTAFirmwareError() bool
	OTAComplete() bool
	Broadcast() bool
	Parts() []string
	PartsLen() int
}

type DeviceEventProvider interface {
	ActivateStreamProvider()
	ApplyDeviceEvent(dm DeviceMessage)
	PublishToStreamProvider(dm DeviceMessage)
	ConsumeDeviceStream(dm DeviceMessage) error
}

type DeviceMessage struct {
	ID          uint16
	HomieType   CoreType
	OTATrigger  bool
	RetainedB   bool
	Qosb        byte
	NetworkID   []byte
	DeviceID    []byte
	NodeID      []byte
	PropertyID  []byte
	PPropertyID []byte
	AttributeID []byte
	TopicS      string
	Value       []byte
}

type DeviceNode struct {
	ID          EID
	ElementType CoreType
	Parent      string
	Name        string
	Attrs       map[string]DeviceNodeAttribute
	Props       map[string]DeviceNodeProperty
}

type DeviceNodeAttribute struct {
	ID          EID
	ElementType CoreType
	Parent      string
	Name        string
	Value       string
}

type DeviceNodeProperty struct {
	ID          EID
	ElementType CoreType
	Parent      string
	Name        string
	Value       string
	Attrs       map[string]DeviceNodePropertyAttribute
}

type DeviceNodePropertyAttribute struct {
	ID          EID
	ElementType CoreType
	Parent      string
	Name        string
	Value       string
}

type EID string

type EntityBuilder interface {
	// contains filtered or unexported methods
}

type Firmware struct {
	ID          EID
	ElementType CoreType
	Name        string
	FileName    string
	Version     string
	Path        string
	Size        int64
	MD5Digest   string
	Brand       string
	Created     time.Time
}

type FirmwareTools interface {
	String()
}

type Network struct {
	ID          string
	Title       string
	ElementType CoreType // network name
	Name        string   // any
	Devices     map[string]Device
}

type OTATransport int

type QueueMessage interface {
	Topic() string
	Payload() []byte
	MessageID() uint16
	Retained() bool
	Qos() byte
	Duplicate() bool
	Ack()
}

type Repository interface {
	Store(d DeviceMessage) error
	Remove(d DeviceMessage) error
	RestoreNetworkFromDB(networkName string) Network
	LoadSchedules() map[string]Schedule
	StoreSchedule(d Schedule) error
	RemoveSchedule(scheduleID string) error
	LoadBroadcasts(networkName string) []Broadcast
	RemoveAllBroadcasts(networkName string) error
}

type Schedule struct {
	ID          string
	ElementType CoreType
	DeviceID    string
	FirmwareID  EID
	State       string
	Status      string
	Retries     int
	Transport   OTATransport
	Scheduled   time.Time
	Completed   time.Time
}

type ScheduleTools interface {
	String()
}

type SchedulerProvider interface {
	ActivateStreamProvider()
	ApplySiteNetworks(sn *SiteNetworks)
	Schedules() []Schedule
	BuildScheduleCatalog() map[string]Schedule
	FindScheduleByDeviceID(deviceID string) *Schedule
	CreateSchedule(networkName string, deviceID string, transport OTATransport, firmwareID EID) (string, error)
	DeleteSchedule(scheduleID string) error
	BuildFirmwareCatalog() []Firmware
	Firmwares() []Firmware
	GetFirmware(id EID) (Firmware, error)
	CreateFirmware(srcFile, dstFile string) (EID, error)
	DeleteFirmware(id EID) error
}

type SiteNetworks struct {
	ID             EID
	ElementType    CoreType // site name
	SiteName       string
	Title          string
	Names          []string // any
	Broadcasts     []Broadcast
	Firmwares      []Firmware
	Schedules      map[string]Schedule // by EID
	DeviceNetworks map[string]Network  // by Device Name
}