From 7b9641f753d422fcd39537b54b7d8081ed2f2b60 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Adrian=20Z=C3=BCrcher?= <zuercher@mst.local>
Date: Tue, 29 Apr 2025 17:02:35 +0200
Subject: [PATCH] add set parameter in websocket

---
 dbm/set.go       | 19 +++++++++++++++++++
 dbm/webSocket.go |  3 +++
 2 files changed, 22 insertions(+)
 create mode 100644 dbm/set.go

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)