add set parameter in websocket

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)
+		}
+	}
+}

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)