86 lines
2.0 KiB
Go
86 lines
2.0 KiB
Go
package driver
|
|
|
|
import (
|
|
"artNet/cfg"
|
|
"artNet/models"
|
|
serverModels "artNet/server/models"
|
|
"fmt"
|
|
"path"
|
|
|
|
"github.com/tecamino/tecamino-logger/logging"
|
|
)
|
|
|
|
type ArtNetDriver struct {
|
|
Name string `yaml:"driver" json:"driver"`
|
|
Buses map[string]*models.Bus `yaml:"buses,omitempty" json:"buses,omitempty"`
|
|
cfgHandler *cfg.Cfg `yaml:"-" json:"-"`
|
|
Connections serverModels.Clients `yaml:"-"`
|
|
Log *logging.Logger `yaml:"-"`
|
|
}
|
|
|
|
// initialize new Art-Net driver
|
|
// cfgDir config directory
|
|
// name name of driver
|
|
func NewDriver(cfgDir, name string, debug bool) (*ArtNetDriver, error) {
|
|
if cfgDir == "" {
|
|
cfgDir = "./cfg"
|
|
}
|
|
|
|
logger, err := logging.NewLogger(path.Join(cfgDir, name+".log"), &logging.Config{
|
|
MaxSize: 1,
|
|
MaxBackup: 3,
|
|
MaxAge: 28,
|
|
Debug: debug,
|
|
TerminalOut: true,
|
|
})
|
|
if err != nil {
|
|
panic(err)
|
|
}
|
|
|
|
logger.Debug("artNet.NewDriver", "initialize "+name+" driver")
|
|
d := ArtNetDriver{
|
|
Name: name,
|
|
Buses: make(map[string]*models.Bus),
|
|
cfgHandler: cfg.NewCfgHandler(cfgDir, name),
|
|
Connections: serverModels.NewClients(),
|
|
Log: logger,
|
|
}
|
|
|
|
if err := d.LoadCfg(); err != nil {
|
|
logger.Error("artNet.NewDriver.LoadCfg", "error load driver configuration: "+err.Error())
|
|
return nil, err
|
|
}
|
|
|
|
return &d, nil
|
|
}
|
|
|
|
// loads driver config
|
|
func (d *ArtNetDriver) LoadCfg() error {
|
|
d.Log.Debug("artNet.LoadCfg", "load driver configuration")
|
|
if err := d.cfgHandler.LoadCfg(d); err != nil {
|
|
return err
|
|
}
|
|
|
|
for _, b := range d.Buses {
|
|
d.NewBus(b.Name, b.Ip, *b.Port)
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// adds new Art-Net bus/interface to driver port 0 = 6454 (default art-net)
|
|
func (d *ArtNetDriver) NewBus(name, ip string, port int) *models.Bus {
|
|
b := models.NewBus(name, ip, port)
|
|
b.Start(d.Log)
|
|
d.Buses[name] = b
|
|
return b
|
|
}
|
|
|
|
func (d *ArtNetDriver) SetValue(set models.Set) error {
|
|
if _, ok := d.Buses[set.Bus]; !ok {
|
|
return fmt.Errorf("no bus '%s' found", set.Bus)
|
|
}
|
|
d.Buses[set.Bus].Data.SetValue(set.Address, set.Value)
|
|
|
|
return d.Buses[set.Bus].SendData()
|
|
}
|