diff --git a/dbm/set.go b/dbm/set.go new file mode 100644 index 0000000..867c41a --- /dev/null +++ b/dbm/set.go @@ -0,0 +1,19 @@ +package dbm + +import ( + json_dataModels "github.com/tecamino/tecamino-json_data/models" +) + +func (d *DBMHandler) Set(sets []json_dataModels.Set) { + if sets == nil { + return + } + d.RLock() + defer d.RUnlock() + + for _, set := range sets { + for _, dp := range d.DB.QueryDatapoints(1, set.Path) { + dp.UpdateValue(d.Conns, set.Value) + } + } +} diff --git a/dbm/webSocket.go b/dbm/webSocket.go index f93bf6e..05d6834 100644 --- a/dbm/webSocket.go +++ b/dbm/webSocket.go @@ -40,6 +40,9 @@ func (d *DBMHandler) WebSocket(c *gin.Context) { break } + // Sets + go d.Set(request.Set) + // Subscribe go d.Subscribe(request.Subscribe, id)