Compare commits
2 Commits
Author | SHA1 | Date | |
---|---|---|---|
![]() |
a92995d766 | ||
![]() |
348a6f7622 |
@@ -50,9 +50,6 @@ func NewDriver(cfgDir, name string, debug bool) (*ArtNetDriver, error) {
|
|||||||
logger.Error("artNet.NewDriver.LoadCfg", "error load driver configuration: "+err.Error())
|
logger.Error("artNet.NewDriver.LoadCfg", "error load driver configuration: "+err.Error())
|
||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
|
|
||||||
d.Conn = client.NewClient(logger)
|
|
||||||
|
|
||||||
return &d, nil
|
return &d, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -81,11 +78,11 @@ func (d *ArtNetDriver) SetValue(bus string, address uint, value uint8) error {
|
|||||||
return fmt.Errorf("no bus '%s' found", bus)
|
return fmt.Errorf("no bus '%s' found", bus)
|
||||||
}
|
}
|
||||||
d.Buses[bus].Data.SetValue(address, value)
|
d.Buses[bus].Data.SetValue(address, value)
|
||||||
|
|
||||||
return d.Buses[bus].SendData()
|
return d.Buses[bus].SendData()
|
||||||
}
|
}
|
||||||
|
|
||||||
func (d *ArtNetDriver) Connect(ip, id string, port uint) error {
|
func (d *ArtNetDriver) Connect(ip, id string, port uint) error {
|
||||||
|
d.Conn = client.NewClient(d.Log)
|
||||||
if err := d.Conn.Connect(ip, id, port); err != nil {
|
if err := d.Conn.Connect(ip, id, port); err != nil {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
@@ -1,49 +0,0 @@
|
|||||||
package driver
|
|
||||||
|
|
||||||
const (
|
|
||||||
OnCreate = "onCreate"
|
|
||||||
OnChange = "onChange"
|
|
||||||
OnDelete = "onDelete"
|
|
||||||
)
|
|
||||||
|
|
||||||
//func (d *ArtNetDriver) Websocket(c *gin.Context) {
|
|
||||||
// id, err := auth.GetIDFromQuery(c)
|
|
||||||
// if err != nil {
|
|
||||||
// d.Log.Error("artNet.webSocket.Websocket", "error GetIDFromAuth: "+err.Error())
|
|
||||||
// return
|
|
||||||
// }
|
|
||||||
// d.Log.Debug("artNet.webSocket.Websocket", "authorization id token: "+id)
|
|
||||||
|
|
||||||
// ctx, cancel := context.WithTimeout(c.Request.Context(), 10*time.Minute)
|
|
||||||
// defer cancel()
|
|
||||||
// conn, err := d.Connections.ConnectRecievingWsConnection(id, c)
|
|
||||||
// if err != nil {
|
|
||||||
// d.Log.Error("artNet.webSocket.Websocket", "error connecting recieving websocket conection: "+err.Error())
|
|
||||||
// return
|
|
||||||
// }
|
|
||||||
// defer d.Connections.DisconnectRecievingWsConnection(id, websocket.StatusInternalError, "Internal error")
|
|
||||||
|
|
||||||
// var request any
|
|
||||||
// //Read loop
|
|
||||||
// for {
|
|
||||||
|
|
||||||
// err := wsjson.Read(ctx, conn, &request)
|
|
||||||
// if err != nil {
|
|
||||||
// d.Log.Error("artNet.webSocket.Websocket", "read error:"+err.Error())
|
|
||||||
// log.Println("WebSocket read error:", err)
|
|
||||||
// break
|
|
||||||
// }
|
|
||||||
// fmt.Println(request)
|
|
||||||
// Set
|
|
||||||
// if request.Set != nil {
|
|
||||||
// for _, set := range *request.Set {
|
|
||||||
// if err = d.SetValue(set); err != nil {
|
|
||||||
// d.Log.Error("artNet.webSocket.Websocket", "set value error"+err.Error())
|
|
||||||
// log.Println(err)
|
|
||||||
// continue
|
|
||||||
// }
|
|
||||||
// time.Sleep(23 * time.Millisecond)
|
|
||||||
// }
|
|
||||||
// }
|
|
||||||
// }
|
|
||||||
// }
|
|
Reference in New Issue
Block a user