add dbm new model and fixed json_data

fix upload artifacts

.github/workflows/build.yml

@@ -0,0 +1,48 @@
+name: Build Go Binaries
+
+on:
+  push:
+    branches: [ main ]
+  pull_request:
+
+jobs:
+  build:
+    runs-on: ubuntu-latest
+
+    strategy:
+      matrix:
+        goos: [linux, windows]
+        goarch: [amd64, arm, arm64]
+        exclude:
+          - goos: windows
+            goarch: arm
+          - goos: windows
+            goarch: arm64
+
+    steps:
+      - uses: actions/checkout@v3
+
+      - name: Set up Go
+        uses: actions/setup-go@v4
+        with:
+          go-version: '1.24.0'
+
+      - name: Set up Git credentials for private modules
+        run: |
+          git config --global url."https://${{ secrets.GH_PAT }}@github.com/".insteadOf "https://github.com/"
+          echo "GOPRIVATE=github.com/tecamino/*" >> $GITHUB_ENV
+
+      - name: Build binary
+        run: |
+          mkdir -p build
+          if [ "${{ matrix.goos }}" == "windows" ]; then
+            GOOS=${{ matrix.goos }} GOARCH=${{ matrix.goarch }} go build -o build/tecamino-dbm-${{ matrix.goos }}-${{ matrix.goarch }}.exe main.go
+          else
+            GOOS=${{ matrix.goos }} GOARCH=${{ matrix.goarch }} go build -o build/tecamino-dbm-${{ matrix.goos }}-${{ matrix.goarch }} main.go
+          fi
+
+      - name: Upload artifacts
+        uses: actions/upload-artifact@v4
+        with:
+          name: binaries-${{ matrix.goos }}-${{ matrix.goarch }}
+          path: build/

args/args.go

@@ -7,6 +7,7 @@ import (
 	"github.com/tecamino/tecamino-dbm/models"
 )
 
+// DBM cli arguments
 type Args struct {
 	Port    models.Port
 	Cert    cert.Cert
@@ -15,6 +16,7 @@ type Args struct {
 	Debug   bool
 }
 
+// initialte cli arguments
 func Init() *Args {
 
 	a := Args{

cert/cert.go

@@ -29,11 +29,11 @@ func NewCertHandler(org string) *Cert {
 func (c *Cert) GenerateSelfSignedCert() error {
 
 	// do not generate certs if they exist
-	// _, err := os.Stat(c.CertFile)
+	_, err := os.Stat(c.CertFile)
-	// _, err2 := os.Stat(c.KeyFile)
+	_, err2 := os.Stat(c.KeyFile)
-	// if !os.IsNotExist(err) && !os.IsNotExist(err2) {
+	if !os.IsNotExist(err) && !os.IsNotExist(err2) {
-	// 	return nil
+		return nil
-	// }
+	}
 
 	priv, err := rsa.GenerateKey(rand.Reader, 2048)
 	if err != nil {

dbm/db.go

@@ -13,13 +13,15 @@ func (d *DBMHandler) SaveData(c *gin.Context) {
 	s := time.Now()
 	if err := d.SaveDb(); err != nil {
 		r := json_dataModels.NewResponse()
-		r.SendError(err.Error())
+		r.SetError()
+		r.SetMessage(err.Error())
 		c.JSON(http.StatusBadRequest, r)
 
 		return
 	}
 
 	r := json_dataModels.NewResponse()
-	r.SendMessage(fmt.Sprintf("DBM %ddatapints saved in: %v", d.GetNumbersOfDatapoints(), time.Since(s)))
+	r.SetMessage(fmt.Sprintf("DBM %d datapoints saved in: %v", d.DBM.GetNumbersOfDatapoints(), time.Since(s)))
+	d.Log.Info("db.SaveData", fmt.Sprintf("DBM %d datapoints saved in: %v", d.DBM.GetNumbersOfDatapoints(), time.Since(s)))
 	c.JSON(http.StatusOK, r)
 }

dbm/dbmHandler.go

@@ -5,29 +5,30 @@ import (
 	"encoding/json"
 	"fmt"
 	"os"
+	"strings"
 	"sync"
 	"time"
 
 	"github.com/tecamino/tecamino-dbm/args"
 	"github.com/tecamino/tecamino-dbm/models"
 	serverModels "github.com/tecamino/tecamino-dbm/server/models"
-	json_dataModels "github.com/tecamino/tecamino-json_data/models"
 	"github.com/tecamino/tecamino-logger/logging"
 )
 
 type DBMHandler struct {
-	filePath string
+	DBM   *models.DBM
-	DB       models.Datapoint
 	Conns *serverModels.Connections
 	sync.RWMutex
 	Log      *logging.Logger
 	arg      *args.Args
+	filePath string
 }
 
 // initialze new Database Manager
 // it will call cli arguments
 func NewDbmHandler(a *args.Args) (*DBMHandler, error) {
 
+	//initialize new logger
 	logger, err := logging.NewLogger("dbmServer.log", &logging.Config{
 		MaxSize:     1,
 		MaxBackup:   3,
@@ -41,12 +42,16 @@ func NewDbmHandler(a *args.Args) (*DBMHandler, error) {
 	}
 	logger.Info("main", "start dma handler")
 
+	//initialize connection map
+	conns := serverModels.NewConnections()
+
 	// Initialize dtabase manager handler
 	dmaHandler := DBMHandler{
 		arg:      a,
 		filePath: fmt.Sprintf("%s/%s.dbm", a.RootDir, a.DBMFile),
+		DBM:      models.NewDBM(conns, logger),
 		Log:      logger,
-		Conns:    serverModels.NewConnections(),
+		Conns:    conns,
 	}
 
 	// initialize system datapoint and periodically update it
@@ -66,16 +71,20 @@ func NewDbmHandler(a *args.Args) (*DBMHandler, error) {
 
 		// read in dtaabase file content
 		scanner := bufio.NewScanner(f)
-
+		var line int
 		for scanner.Scan() {
+			line++
 			dp := models.Datapoint{}
 			if err = json.Unmarshal(scanner.Bytes(), &dp); err != nil {
+				dmaHandler.Log.Error("dmbHandler.NewDmbHandler", "error in line "+fmt.Sprint(line)+" "+scanner.Text())
+				dmaHandler.Log.Error("dmbHandler.NewDmbHandler", err.Error())
+
 				return nil, err
 			}
-			dmaHandler.ImportDatapoints(dp)
+			dmaHandler.DBM.ImportDatapoints(dp)
 		}
 	}
-	dmaHandler.Log.Info("dmbHandler.NewDmbHandler", fmt.Sprintf("%d datapoint imported in %v", dmaHandler.GetNumbersOfDatapoints(), time.Since(s)))
+	dmaHandler.Log.Info("dmbHandler.NewDmbHandler", fmt.Sprintf("%d datapoint imported in %v", dmaHandler.DBM.GetNumbersOfDatapoints(), time.Since(s)))
 	return &dmaHandler, nil
 }
 
@@ -86,7 +95,13 @@ func (d *DBMHandler) SaveDb() (err error) {
 	}
 	defer f.Close()
 
-	for _, dp := range d.DB.GetAllDatapoints(0) {
+	for _, dp := range d.DBM.GetAllDatapoints(0) {
+		//exclude System datapoints from saving
+		//System datapoints are used for internal purposes and should not be saved in the database
+		if strings.Contains(dp.Path, "System:") {
+			continue
+		}
+
 		b, er := json.Marshal(dp)
 		if er != nil {
 			return er
@@ -103,59 +118,3 @@ func (d *DBMHandler) SaveDb() (err error) {
 	}
 	return
 }
-
-func (d *DBMHandler) CreateDatapoints(sets ...json_dataModels.Set) ([]json_dataModels.Set, error) {
-	if len(sets) == 0 {
-		return nil, nil
-	}
-
-	dps, err := d.DB.CreateDatapoints(d.Conns, sets...)
-	if err != nil {
-		return nil, err
-	}
-
-	var ndp uint64
-	for _, dp := range dps {
-		if !dp.Updated {
-			ndp++
-		}
-	}
-	dp := d.QueryDatapoints(1, "System:Datapoints")
-	d.UpdateDatapointValue("System:Datapoints", dp[0].GetValueUint64()+ndp)
-	return dps, nil
-}
-
-func (d *DBMHandler) ImportDatapoints(dps ...models.Datapoint) error {
-	for _, dp := range dps {
-		err := d.DB.ImportDatapoint(d.Conns, dp, dp.Path)
-		if err != nil {
-			return err
-		}
-		dp := d.QueryDatapoints(1, "System:Datapoints")
-		d.UpdateDatapointValue("System:Datapoints", dp[0].GetValueUint64()+1)
-	}
-	return nil
-}
-
-func (d *DBMHandler) UpdateDatapointValue(path string, value any) error {
-	return d.DB.UpdateDatapointValue(d.Conns, value, path)
-}
-
-func (d *DBMHandler) RemoveDatapoint(sets ...json_dataModels.Set) ([]json_dataModels.Set, error) {
-	var lsRemoved []json_dataModels.Set
-	for _, set := range sets {
-		removed, err := d.DB.RemoveDatapoint(d.Conns, set)
-		if err != nil {
-			return lsRemoved, err
-		}
-		lsRemoved = append(lsRemoved, removed)
-		dp := d.QueryDatapoints(1, "System:Datapoints")
-		d.UpdateDatapointValue("System:Datapoints", dp[0].GetValueUint64()-1)
-	}
-
-	return lsRemoved, nil
-}
-
-func (d *DBMHandler) QueryDatapoints(depth uint, key string) []*models.Datapoint {
-	return d.DB.QueryDatapoints(depth, key)
-}

dbm/get.go

@@ -0,0 +1,39 @@
+package dbm
+
+import (
+	json_data "github.com/tecamino/tecamino-json_data"
+	json_dataModels "github.com/tecamino/tecamino-json_data/models"
+)
+
+func (d *DBMHandler) Get(req *json_dataModels.Request, id string) {
+	if req == nil {
+		return
+	} else if len(req.Get) == 0 {
+		return
+	}
+	d.RLock()
+	defer d.RUnlock()
+
+	resp := json_data.NewResponse()
+	resp.Id = req.Id
+	for _, get := range req.Get {
+		var depth uint = 1
+		if get.Query != nil {
+			depth = get.Query.Depth
+		}
+
+		for _, dp := range d.DBM.QueryDatapoints(depth, get.Uuid, get.Path) {
+			resp.AddGet(json_dataModels.Get{
+				Uuid:   dp.Uuid,
+				Path:   dp.Path,
+				Type:   dp.Type,
+				Value:  dp.Value,
+				Rights: dp.ReadWrite,
+			})
+		}
+	}
+
+	if err := d.Conns.SendResponse(id, resp); err != nil {
+		d.Log.Error("get.Get", err.Error())
+	}
+}

dbm/json_data.go

@@ -9,11 +9,13 @@ import (
 )
 
 func (d *DBMHandler) Json_Data(c *gin.Context) {
+
 	var err error
 	payload, err := json_data.ParseRequest(c.Request.Body)
 	if err != nil {
 		r := json_data.NewResponse()
-		r.SendError(err.Error())
+		r.SetError()
+		r.SetMessage(err.Error())
 		c.JSON(http.StatusBadRequest, r)
 		return
 	}
@@ -26,8 +28,7 @@ func (d *DBMHandler) Json_Data(c *gin.Context) {
 			if get.Query != nil {
 				depth = get.Query.Depth
 			}
-
+			for _, res := range d.DBM.QueryDatapoints(depth, get.Uuid, get.Path) {
-			for _, res := range d.QueryDatapoints(depth, get.Path) {
 				respond.AddGet(json_dataModels.Get{
 					Uuid:    res.Uuid,
 					Path:    res.Path,
@@ -41,17 +42,17 @@ func (d *DBMHandler) Json_Data(c *gin.Context) {
 
 	}
 	if payload.Set != nil {
-		respond.Set, err = d.CreateDatapoints(payload.Set...)
+		respond.Set, err = d.DBM.CreateDatapoints(payload.Set...)
 		if err != nil {
 			r := json_data.NewResponse()
-			r.SendError(err.Error())
+			r.SetError()
+			r.SetMessage(err.Error())
 			c.JSON(http.StatusBadRequest, r)
 			return
 		}
 	}
 
 	c.JSON(200, respond)
-	return
 }
 
 func (d *DBMHandler) Delete(c *gin.Context) {
@@ -59,7 +60,8 @@ func (d *DBMHandler) Delete(c *gin.Context) {
 	payload, err := json_data.ParseRequest(c.Request.Body)
 	if err != nil {
 		r := json_data.NewResponse()
-		r.SendError(err.Error())
+		r.SetError()
+		r.SetMessage(err.Error())
 		c.JSON(http.StatusBadRequest, r)
 		return
 	}
@@ -68,15 +70,15 @@ func (d *DBMHandler) Delete(c *gin.Context) {
 
 	if payload.Set != nil {
 
-		response.Set, err = d.RemoveDatapoint(payload.Set...)
+		response.Set, err = d.DBM.RemoveDatapoint(payload.Set...)
 		if err != nil {
 			r := json_data.NewResponse()
-			r.SendError(err.Error())
+			r.SetError()
+			r.SetMessage(err.Error())
 			c.JSON(http.StatusBadRequest, r)
 			return
 		}
 	}
 
 	c.JSON(200, response)
-	return
 }

dbm/set.go

@@ -0,0 +1,21 @@
+package dbm
+
+import (
+	json_dataModels "github.com/tecamino/tecamino-json_data/models"
+)
+
+func (d *DBMHandler) Set(req *json_dataModels.Request) {
+	if req == nil {
+		return
+	} else if len(req.Set) == 0 {
+		return
+	}
+	d.RLock()
+	defer d.RUnlock()
+
+	for _, set := range req.Set {
+		for _, dp := range d.DBM.QueryDatapoints(1, set.Uuid, set.Path) {
+			dp.UpdateValue(d.Conns, set.Value)
+		}
+	}
+}

dbm/subscribe.go

@@ -1,34 +1,31 @@
 package dbm
 
 import (
-	"github.com/coder/websocket/wsjson"
 	json_dataModels "github.com/tecamino/tecamino-json_data/models"
 )
 
-func (d *DBMHandler) Subscribe(subs []json_dataModels.Subscribe, id string) {
+func (d *DBMHandler) Subscribe(req *json_dataModels.Request, id string) {
-	if subs == nil {
+	if req == nil {
+		return
+	}
+	if len(req.Subscribe) == 0 {
 		return
 	}
 	d.RLock()
 	defer d.RUnlock()
 
-	client, ok := d.Conns.Clients[id]
+	resp := json_dataModels.NewResponse()
-	if !ok {
+	resp.Id = req.Id
-		d.Log.Error("subscribe.Subscribe", "client not found for id "+id)
-		return
-	}
 
-	response := json_dataModels.NewResponse()
+	for _, sub := range req.Subscribe {
-
+		for _, dp := range d.DBM.QueryDatapoints(sub.Depth, sub.Uuid, sub.Path) {
-	for _, sub := range subs {
-		for _, dp := range d.DB.QueryDatapoints(sub.Depth, sub.Path) {
 			if sub.Driver != "" {
 				if dp.Drivers == nil || dp.Drivers[sub.Driver] == nil {
 					continue
 				}
 			}
 			dp.AddSubscribtion(id, sub)
-			response.AddSubscription(json_dataModels.Subscribe{
+			resp.AddSubscription(json_dataModels.Subscription{
 				Uuid:    dp.Uuid,
 				Path:    dp.Path,
 				Value:   dp.Value,
@@ -37,39 +34,38 @@ func (d *DBMHandler) Subscribe(subs []json_dataModels.Subscribe, id string) {
 			})
 		}
 	}
-	if err := wsjson.Write(client.Ctx, client.Conn, response); err != nil {
+
+	if err := d.Conns.SendResponse(id, resp); err != nil {
 		d.Log.Error("subscribe.Subscribe", err.Error())
 	}
 }
 
-func (d *DBMHandler) Unsubscribe(subs []json_dataModels.Subscribe, id string) {
+func (d *DBMHandler) Unsubscribe(req *json_dataModels.Request, id string) {
-	if subs == nil {
+	if req == nil {
+		return
+	}
+	if len(req.Unsubscribe) == 0 {
 		return
 	}
 	d.RLock()
 	defer d.RUnlock()
 
-	client, ok := d.Conns.Clients[id]
+	resp := json_dataModels.NewResponse()
-	if !ok {
+	resp.Id = req.Id
-		d.Log.Error("subscribe.Subscribe", "client not found for id "+id)
-		return
-	}
 
-	response := json_dataModels.NewResponse()
+	for _, sub := range req.Unsubscribe {
-
+		for _, dp := range d.DBM.QueryDatapoints(sub.Depth, sub.Uuid, sub.Path) {
-	for _, sub := range subs {
-		for _, dp := range d.DB.QueryDatapoints(sub.Depth, sub.Path) {
 			if _, ok := dp.Subscriptions[id]; !ok {
 				continue
 			}
 			dp.RemoveSubscribtion(id)
-			response.AddUnsubscription(json_dataModels.Subscribe{
+			resp.AddUnsubscription(json_dataModels.Subscription{
 				Uuid: dp.Uuid,
 				Path: dp.Path,
 			})
 		}
 	}
-	if err := wsjson.Write(client.Ctx, client.Conn, response); err != nil {
+	if err := d.Conns.SendResponse(id, resp); err != nil {
-		d.Log.Error("subscribe.Subscribe", err.Error())
+		d.Log.Error("subscribe.Unsubscribe", err.Error())
 	}
 }

dbm/system.go

@@ -1,11 +1,8 @@
 package dbm
 
 import (
-	"fmt"
+	"github.com/google/uuid"
-	"runtime"
+	"github.com/tecamino/tecamino-dbm/models"
-	"time"
-
-	"github.com/tecamino/tecamino-dbm/utils"
 	json_dataModels "github.com/tecamino/tecamino-json_data/models"
 )
 
@@ -14,84 +11,19 @@ func (d *DBMHandler) AddSystemDps() (err error) {
 
 	typ := json_dataModels.LOU
 	rights := json_dataModels.Read
-	_, err = d.DB.CreateDatapoints(d.Conns, json_dataModels.Set{Path: path, Value: 0, Type: typ, Rights: rights})
+	_, err = d.DBM.CreateDatapoints(json_dataModels.Set{Path: path, Value: 0, Type: typ, Rights: rights})
 	if err != nil {
 		d.Log.Error("dmb.Handler.AddSystemDps", err.Error())
 		return err
 	}
-	dp := d.QueryDatapoints(1, path)
+	models.SystemDatapoints = d.DBM.QueryDatapoints(1, uuid.Nil, path)[0].Uuid
-	d.UpdateDatapointValue(path, dp[0].GetValueUint64()+1)
 
-	if err = d.GoSystemTime(); err != nil {
+	if err = d.DBM.GoSystemTime(); err != nil {
 		return err
 	}
 
-	if err = d.GoSystemMemory(); err != nil {
+	if err = d.DBM.GoSystemMemory(); err != nil {
 		return err
 	}
 	return
 }
-
-func (d *DBMHandler) GetNumbersOfDatapoints() uint64 {
-	return utils.Uint64From(d.DB.Datapoints["System"].Datapoints["Datapoints"].Value)
-}
-
-func (d *DBMHandler) GoSystemTime() error {
-	path := "System:Time"
-	var tOld int64
-
-	typ := json_dataModels.STR
-	rights := json_dataModels.Read
-	_, err := d.DB.CreateDatapoints(d.Conns, json_dataModels.Set{Path: path, Type: typ, Rights: rights})
-	if err != nil {
-		d.Log.Error("system.GoSystemTime", err.Error())
-		return err
-	}
-	dp := d.QueryDatapoints(1, "System:Datapoints")
-	d.UpdateDatapointValue("System:Datapoints", dp[0].GetValueUint64()+1)
-
-	go func() {
-		for {
-			t := time.Now().UnixMilli()
-			if tOld != t {
-				if er := d.DB.UpdateDatapointValue(d.Conns, t, path); er != nil {
-					d.Log.Error("dmb.Handler.AddSystemDps.UpdateDatapointValue", er.Error())
-				}
-				tOld = t
-			}
-			time.Sleep(time.Second)
-		}
-	}()
-	return nil
-}
-
-func (d *DBMHandler) GoSystemMemory() error {
-	path := "System:UsedMemory"
-	var m runtime.MemStats
-	var mOld uint64
-
-	typ := json_dataModels.STR
-	rights := json_dataModels.Read
-	_, err := d.DB.CreateDatapoints(d.Conns, json_dataModels.Set{Path: path, Type: typ, Rights: rights})
-	if err != nil {
-		d.Log.Error("system.GoSystemMemory", err.Error())
-		return err
-	}
-	dp := d.QueryDatapoints(1, "System:Datapoints")
-	d.UpdateDatapointValue("System:Datapoints", dp[0].GetValueUint64()+1)
-
-	go func() {
-		for {
-			runtime.ReadMemStats(&m)
-			if m.Sys != mOld {
-				mem := fmt.Sprintf("%.2f MB", float64(m.Sys)/1024/1024)
-				if er := d.DB.UpdateDatapointValue(d.Conns, mem, path); er != nil {
-					d.Log.Error("dmb.Handler.AddSystemDps.UpdateDatapointValue", er.Error())
-				}
-				mOld = m.Sys
-			}
-			time.Sleep(time.Second)
-		}
-	}()
-	return nil
-}

dbm/webSocket.go

@@ -1,11 +1,12 @@
 package dbm
 
 import (
+	"encoding/json"
 	"errors"
 	"fmt"
+	"io"
 
 	"github.com/coder/websocket"
-	"github.com/coder/websocket/wsjson"
 	"github.com/gin-gonic/gin"
 	"github.com/tecamino/tecamino-dbm/auth"
 	json_dataModels "github.com/tecamino/tecamino-json_data/models"
@@ -35,28 +36,48 @@ func (d *DBMHandler) WebSocket(c *gin.Context) {
 
 	//Read loop
 	for {
+
 		request, err := d.readJsonData(id)
 		if err != nil {
+			d.Log.Error("websocket.WebSocket", err.Error())
 			break
 		}
 
+		// Sets
+
+		d.Get(request, id)
+		// Sets
+		d.Set(request)
+
 		// Subscribe
-		go d.Subscribe(request.Subscribe, id)
+		d.Subscribe(request, id)
 
 		// Unsubscribe
-		go d.Unsubscribe(request.Unsubscribe, id)
+		d.Unsubscribe(request, id)
 
+		request.Get = make([]json_dataModels.Get, 0)
+		request.Set = make([]json_dataModels.Set, 0)
+		request.Subscribe = make([]json_dataModels.Subscription, 0)
+		request.Unsubscribe = make([]json_dataModels.Subscription, 0)
+		request = nil
 	}
 }
 
-func (d *DBMHandler) readJsonData(id string) (request json_dataModels.Request, err error) {
+func (d *DBMHandler) readJsonData(id string) (request *json_dataModels.Request, err error) {
 
 	client, ok := d.Conns.Clients[id]
 	if !ok {
 		return request, errors.New("client id not found")
 	}
 
-	err = wsjson.Read(client.Ctx, client.Conn, &request)
+	_, reader, err := client.Conn.Reader(client.Ctx)
+	if err != nil {
+		d.Log.Info("webSocket.readJsonData", fmt.Sprintf("WebSocket reader: %v\n", err))
+		return request, nil
+	}
+
+	b, err := io.ReadAll(reader)
+
 	if err != nil {
 		code := websocket.CloseStatus(err)
 
@@ -71,5 +92,10 @@ func (d *DBMHandler) readJsonData(id string) (request json_dataModels.Request, e
 			return
 		}
 	}
+
+	if err := json.Unmarshal(b, &request); err != nil {
+		return request, err
+	}
+
 	return
 }

dbmServer.log

@@ -1,545 +0,0 @@
-{"level":"info","timestamp":"2025-04-24T12:45:01.930","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T12:45:02.868","msg":"70906 datapoint imported in 930.8401ms","caller":"dmbHandler.NewDmbHandler"}
-{"level":"info","timestamp":"2025-04-24T12:45:02.869","msg":"https listen on 8101","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T12:45:02.869","msg":"http listen on 8100","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T12:47:06.093","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T12:47:07.041","msg":"70906 datapoint imported in %!f(time.Duration=940757100).2f","caller":"dmbHandler.NewDmbHandler"}
-{"level":"info","timestamp":"2025-04-24T12:47:07.042","msg":"https listen on 8101","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T12:47:07.042","msg":"http listen on 8100","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T12:47:42.138","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T12:47:43.171","msg":"70906 datapoint imported in %!f(time.Duration=1025908600)","caller":"dmbHandler.NewDmbHandler"}
-{"level":"info","timestamp":"2025-04-24T12:47:43.172","msg":"https listen on 8101","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T12:47:43.172","msg":"http listen on 8100","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T12:48:45.213","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T12:48:46.191","msg":"70906 datapoint imported in 971443100.00","caller":"dmbHandler.NewDmbHandler"}
-{"level":"info","timestamp":"2025-04-24T12:48:46.193","msg":"https listen on 8101","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T12:48:46.193","msg":"http listen on 8100","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T12:57:28.741","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T12:57:29.696","msg":"70906 datapoint imported in 947.9423ms","caller":"dmbHandler.NewDmbHandler"}
-{"level":"info","timestamp":"2025-04-24T12:57:29.697","msg":"https listen on 8101","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T12:57:29.699","msg":"http listen on 8100","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T12:57:52.592","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T12:57:53.564","msg":"70906 datapoint imported in 965.8849ms","caller":"dmbHandler.NewDmbHandler"}
-{"level":"info","timestamp":"2025-04-24T12:57:53.565","msg":"https listen on 8101","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T12:57:53.565","msg":"http listen on 8100","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T14:26:52.685","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T14:26:53.699","msg":"70904 datapoint imported in 1.0068394s","caller":"dmbHandler.NewDmbHandler"}
-{"level":"info","timestamp":"2025-04-24T14:26:53.701","msg":"https listen on 8101","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T14:26:53.701","msg":"http listen on 8100","caller":"main"}
-{"level":"error","timestamp":"2025-04-24T14:29:02.257","msg":"WebSocket read error: failed to read JSON message: failed to unmarshal JSON: json: cannot unmarshal string into Go struct field Subscribe.subscribe.depth of type int (code: StatusCode(-1))\n","caller":"webSocket.readJsonData"}
-{"level":"error","timestamp":"2025-04-24T14:29:19.514","msg":"WebSocket read error: failed to read JSON message: failed to unmarshal JSON: invalid character ']' looking for beginning of value (code: StatusCode(-1))\n","caller":"webSocket.readJsonData"}
-{"level":"error","timestamp":"2025-04-24T14:29:28.650","msg":"WebSocket read error: failed to read JSON message: failed to unmarshal JSON: invalid character '}' looking for beginning of object key string (code: StatusCode(-1))\n","caller":"webSocket.readJsonData"}
-{"level":"error","timestamp":"2025-04-24T14:30:04.426","msg":"WebSocket read error: failed to read JSON message: failed to unmarshal JSON: json: cannot unmarshal string into Go struct field Subscribe.subscribe.depth of type int (code: StatusCode(-1))\n","caller":"webSocket.readJsonData"}
-{"level":"info","timestamp":"2025-04-24T14:33:04.647","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T14:33:06.213","msg":"70904 datapoint imported in 1.5589017s","caller":"dmbHandler.NewDmbHandler"}
-{"level":"info","timestamp":"2025-04-24T14:33:06.213","msg":"https listen on 8101","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T14:33:06.213","msg":"http listen on 8100","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T14:33:32.445","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T14:33:34.159","msg":"70904 datapoint imported in 1.7024539s","caller":"dmbHandler.NewDmbHandler"}
-{"level":"info","timestamp":"2025-04-24T14:33:34.159","msg":"https listen on 8101","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T14:33:34.159","msg":"http listen on 8100","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T14:34:45.855","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T14:34:50.869","msg":"70904 datapoint imported in 5.0089018s","caller":"dmbHandler.NewDmbHandler"}
-{"level":"info","timestamp":"2025-04-24T14:34:50.870","msg":"https listen on 8101","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T14:34:50.870","msg":"http listen on 8100","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T14:35:41.131","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T14:35:49.457","msg":"70904 datapoint imported in 8.3191437s","caller":"dmbHandler.NewDmbHandler"}
-{"level":"info","timestamp":"2025-04-24T14:35:49.458","msg":"https listen on 8101","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T14:35:49.458","msg":"http listen on 8100","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T14:38:49.103","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T14:38:56.951","msg":"70904 datapoint imported in 7.8416317s","caller":"dmbHandler.NewDmbHandler"}
-{"level":"info","timestamp":"2025-04-24T14:38:56.952","msg":"https listen on 8101","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T14:38:56.952","msg":"http listen on 8100","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T14:39:49.904","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T14:39:50.870","msg":"70904 datapoint imported in 959.4998ms","caller":"dmbHandler.NewDmbHandler"}
-{"level":"info","timestamp":"2025-04-24T14:39:50.870","msg":"https listen on 8101","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T14:39:50.870","msg":"http listen on 8100","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T14:43:33.774","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T14:43:34.868","msg":"70904 datapoint imported in 1.0850744s","caller":"dmbHandler.NewDmbHandler"}
-{"level":"info","timestamp":"2025-04-24T14:43:34.869","msg":"https listen on 8101","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T14:43:34.869","msg":"http listen on 8100","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T14:48:36.342","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T14:48:37.416","msg":"70904 datapoint imported in 1.0652234s","caller":"dmbHandler.NewDmbHandler"}
-{"level":"info","timestamp":"2025-04-24T14:48:37.417","msg":"https listen on 8101","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T14:48:37.417","msg":"http listen on 8100","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T14:49:34.042","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T14:49:35.084","msg":"70904 datapoint imported in 1.0351849s","caller":"dmbHandler.NewDmbHandler"}
-{"level":"info","timestamp":"2025-04-24T14:49:35.085","msg":"https listen on 8101","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T14:49:35.085","msg":"http listen on 8100","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T14:50:17.667","msg":"WebSocket closed: failed to read JSON message: failed to get reader: received close frame: status = StatusGoingAway and reason = \"\" (code: StatusGoingAway)\n","caller":"webSocket.readJsonData"}
-{"level":"info","timestamp":"2025-04-24T14:52:45.697","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T14:52:46.702","msg":"70904 datapoint imported in 997.5948ms","caller":"dmbHandler.NewDmbHandler"}
-{"level":"info","timestamp":"2025-04-24T14:52:46.703","msg":"https listen on 8101","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T14:52:46.703","msg":"http listen on 8100","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T16:08:44.184","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T16:08:45.189","msg":"70904 datapoint imported in 998.5883ms","caller":"dmbHandler.NewDmbHandler"}
-{"level":"info","timestamp":"2025-04-24T16:08:45.190","msg":"https listen on 8101","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T16:08:45.190","msg":"http listen on 8100","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T16:30:17.557","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T16:30:18.637","msg":"70904 datapoint imported in 1.0739246s","caller":"dmbHandler.NewDmbHandler"}
-{"level":"info","timestamp":"2025-04-24T16:30:18.639","msg":"https listen on 8101","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T16:30:18.639","msg":"http listen on 8100","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T16:35:58.063","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T16:35:59.186","msg":"70907 datapoint imported in 1.1117907s","caller":"dmbHandler.NewDmbHandler"}
-{"level":"info","timestamp":"2025-04-24T16:35:59.187","msg":"https listen on 8101","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T16:35:59.187","msg":"http listen on 8100","caller":"main"}
-{"level":"error","timestamp":"2025-04-24T16:36:04.516","msg":"error GetIDFromQuery: id missing","caller":"dbmHandler.webSocket.Websocket"}
-{"level":"info","timestamp":"2025-04-24T16:36:29.461","msg":"WebSocket closed: failed to read JSON message: failed to get reader: received close frame: status = StatusNoStatusRcvd and reason = \"\" (code: StatusNoStatusRcvd)\n","caller":"webSocket.readJsonData"}
-{"level":"info","timestamp":"2025-04-24T16:37:25.546","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T16:37:26.683","msg":"70907 datapoint imported in 1.1293837s","caller":"dmbHandler.NewDmbHandler"}
-{"level":"info","timestamp":"2025-04-24T16:37:26.685","msg":"https listen on 8101","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T16:37:26.685","msg":"http listen on 8100","caller":"main"}
-{"level":"error","timestamp":"2025-04-24T16:37:33.281","msg":"WebSocket read error: failed to read JSON message: failed to unmarshal JSON: invalid character '}' looking for beginning of object key string (code: StatusCode(-1))\n","caller":"webSocket.readJsonData"}
-{"level":"error","timestamp":"2025-04-24T16:37:38.731","msg":"WebSocket read error: failed to read JSON message: failed to unmarshal JSON: invalid character '}' looking for beginning of object key string (code: StatusCode(-1))\n","caller":"webSocket.readJsonData"}
-{"level":"info","timestamp":"2025-04-24T16:38:43.381","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T16:38:44.403","msg":"70907 datapoint imported in 1.0144352s","caller":"dmbHandler.NewDmbHandler"}
-{"level":"info","timestamp":"2025-04-24T16:38:44.405","msg":"https listen on 8101","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T16:38:44.405","msg":"http listen on 8100","caller":"main"}
-{"level":"error","timestamp":"2025-04-24T16:39:02.357","msg":"WebSocket read error: failed to read JSON message: failed to unmarshal JSON: invalid character 'A' after object key (code: StatusCode(-1))\n","caller":"webSocket.readJsonData"}
-{"level":"info","timestamp":"2025-04-24T16:40:52.392","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T16:40:53.418","msg":"70907 datapoint imported in 1.0194209s","caller":"dmbHandler.NewDmbHandler"}
-{"level":"info","timestamp":"2025-04-24T16:40:53.424","msg":"http listen on 8100","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T16:40:53.424","msg":"https listen on 8101","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T16:41:42.848","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T16:41:43.839","msg":"70907 datapoint imported in 985.2872ms","caller":"dmbHandler.NewDmbHandler"}
-{"level":"info","timestamp":"2025-04-24T16:41:43.840","msg":"https listen on 8101","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T16:41:43.840","msg":"http listen on 8100","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T16:42:41.443","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T16:42:42.505","msg":"70907 datapoint imported in 1.0560975s","caller":"dmbHandler.NewDmbHandler"}
-{"level":"info","timestamp":"2025-04-24T16:42:42.505","msg":"https listen on 8101","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T16:42:42.505","msg":"http listen on 8100","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T16:47:25.135","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T16:47:26.111","msg":"70907 datapoint imported in 968.3434ms","caller":"dmbHandler.NewDmbHandler"}
-{"level":"info","timestamp":"2025-04-24T16:47:26.112","msg":"https listen on 8101","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T16:47:26.112","msg":"http listen on 8100","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T16:48:13.506","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T16:48:14.465","msg":"70907 datapoint imported in 951.0514ms","caller":"dmbHandler.NewDmbHandler"}
-{"level":"info","timestamp":"2025-04-24T16:48:14.466","msg":"https listen on 8101","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T16:48:14.466","msg":"http listen on 8100","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T16:49:36.877","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T16:49:37.849","msg":"70907 datapoint imported in 964.333ms","caller":"dmbHandler.NewDmbHandler"}
-{"level":"info","timestamp":"2025-04-24T16:49:37.850","msg":"https listen on 8101","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T16:49:37.850","msg":"http listen on 8100","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T16:50:00.974","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T16:50:01.984","msg":"70907 datapoint imported in 1.0032639s","caller":"dmbHandler.NewDmbHandler"}
-{"level":"info","timestamp":"2025-04-24T16:50:01.985","msg":"https listen on 8101","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T16:50:01.985","msg":"http listen on 8100","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T16:50:50.119","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T16:50:51.108","msg":"70907 datapoint imported in 981.7711ms","caller":"dmbHandler.NewDmbHandler"}
-{"level":"info","timestamp":"2025-04-24T16:50:51.110","msg":"https listen on 8101","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T16:50:51.110","msg":"http listen on 8100","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T16:52:01.560","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T16:52:02.564","msg":"70907 datapoint imported in 997.4066ms","caller":"dmbHandler.NewDmbHandler"}
-{"level":"info","timestamp":"2025-04-24T16:52:02.565","msg":"https listen on 8101","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T16:52:02.565","msg":"http listen on 8100","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T16:52:34.461","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T16:52:35.449","msg":"70907 datapoint imported in 981.7288ms","caller":"dmbHandler.NewDmbHandler"}
-{"level":"info","timestamp":"2025-04-24T16:52:35.452","msg":"https listen on 8101","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T16:52:35.452","msg":"http listen on 8100","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T16:55:07.627","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T16:55:08.567","msg":"70907 datapoint imported in 934.6237ms","caller":"dmbHandler.NewDmbHandler"}
-{"level":"info","timestamp":"2025-04-24T16:55:08.568","msg":"https listen on 8101","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T16:55:08.568","msg":"http listen on 8100","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T16:56:30.243","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T16:56:31.228","msg":"70907 datapoint imported in 977.9019ms","caller":"dmbHandler.NewDmbHandler"}
-{"level":"info","timestamp":"2025-04-24T16:56:31.229","msg":"https listen on 8101","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T16:56:31.229","msg":"http listen on 8100","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T17:07:51.586","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T17:07:52.531","msg":"70907 datapoint imported in 937.0328ms","caller":"dmbHandler.NewDmbHandler"}
-{"level":"info","timestamp":"2025-04-24T17:07:52.532","msg":"https listen on 8101","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T17:07:52.532","msg":"http listen on 8100","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T17:09:24.427","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T17:09:25.452","msg":"70907 datapoint imported in 1.017777s","caller":"dmbHandler.NewDmbHandler"}
-{"level":"info","timestamp":"2025-04-24T17:09:25.453","msg":"https listen on 8101","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T17:09:25.453","msg":"http listen on 8100","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T17:11:19.652","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T17:11:20.695","msg":"70907 datapoint imported in 1.0316411s","caller":"dmbHandler.NewDmbHandler"}
-{"level":"info","timestamp":"2025-04-24T17:11:20.696","msg":"https listen on 8101","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T17:11:20.697","msg":"http listen on 8100","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T17:11:43.081","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T17:11:44.068","msg":"70907 datapoint imported in 980.6224ms","caller":"dmbHandler.NewDmbHandler"}
-{"level":"info","timestamp":"2025-04-24T17:11:44.069","msg":"https listen on 8101","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T17:11:44.069","msg":"http listen on 8100","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T17:12:10.213","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T17:12:11.161","msg":"70907 datapoint imported in 941.7594ms","caller":"dmbHandler.NewDmbHandler"}
-{"level":"info","timestamp":"2025-04-24T17:12:11.164","msg":"https listen on 8101","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T17:12:11.164","msg":"http listen on 8100","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T17:15:24.635","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T17:15:25.786","msg":"70907 datapoint imported in 1.1437172s","caller":"dmbHandler.NewDmbHandler"}
-{"level":"info","timestamp":"2025-04-24T17:15:25.787","msg":"https listen on 8101","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T17:15:25.787","msg":"http listen on 8100","caller":"main"}
-{"level":"error","timestamp":"2025-04-24T17:27:35.012","msg":"WebSocket read error: failed to read JSON message: failed to get reader: failed to read frame header: read tcp 127.0.0.1:8100->127.0.0.1:57316: wsarecv: An existing connection was forcibly closed by the remote host. (code: StatusCode(-1))\n","caller":"webSocket.readJsonData"}
-{"level":"error","timestamp":"2025-04-24T17:28:16.370","msg":"WebSocket read error: failed to read JSON message: failed to get reader: failed to read frame header: read tcp 127.0.0.1:8100->127.0.0.1:57322: wsarecv: An existing connection was forcibly closed by the remote host. (code: StatusCode(-1))\n","caller":"webSocket.readJsonData"}
-{"level":"error","timestamp":"2025-04-24T17:30:19.143","msg":"WebSocket read error: failed to read JSON message: failed to get reader: failed to read frame header: read tcp 127.0.0.1:8100->127.0.0.1:57341: wsarecv: An existing connection was forcibly closed by the remote host. (code: StatusCode(-1))\n","caller":"webSocket.readJsonData"}
-{"level":"error","timestamp":"2025-04-24T17:31:03.932","msg":"WebSocket read error: failed to read JSON message: failed to unmarshal JSON: json: cannot unmarshal object into Go struct field Subscribe.subscribe.driver of type string (code: StatusCode(-1))\n","caller":"webSocket.readJsonData"}
-{"level":"error","timestamp":"2025-04-24T17:31:39.623","msg":"WebSocket read error: failed to read JSON message: failed to unmarshal JSON: json: cannot unmarshal object into Go struct field Subscribe.subscribe.driver of type string (code: StatusCode(-1))\n","caller":"webSocket.readJsonData"}
-{"level":"error","timestamp":"2025-04-24T17:33:00.875","msg":"WebSocket read error: failed to read JSON message: failed to get reader: failed to read frame header: read tcp 127.0.0.1:8100->127.0.0.1:57377: wsarecv: An existing connection was forcibly closed by the remote host. (code: StatusCode(-1))\n","caller":"webSocket.readJsonData"}
-{"level":"info","timestamp":"2025-04-24T18:43:46.137","msg":"start dma handler","caller":"main"}
-{"level":"error","timestamp":"2025-04-24T18:43:46.146","msg":"driver information missing","caller":"dmb.Handler.AddSystemDps"}
-{"level":"info","timestamp":"2025-04-24T18:44:54.586","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T18:44:56.165","msg":"70907 datapoint imported in 1.5670177s","caller":"dmbHandler.NewDmbHandler"}
-{"level":"info","timestamp":"2025-04-24T18:44:56.167","msg":"https listen on 8101","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T18:44:56.167","msg":"http listen on 8100","caller":"main"}
-{"level":"error","timestamp":"2025-04-24T18:47:15.899","msg":"WebSocket read error: failed to read JSON message: failed to get reader: failed to read frame header: read tcp 127.0.0.1:8100->127.0.0.1:52319: wsarecv: An existing connection was forcibly closed by the remote host. (code: StatusCode(-1))\n","caller":"webSocket.readJsonData"}
-{"level":"error","timestamp":"2025-04-24T19:04:24.211","msg":"WebSocket read error: failed to read JSON message: failed to get reader: failed to read frame header: read tcp 127.0.0.1:8100->127.0.0.1:52325: wsarecv: An existing connection was forcibly closed by the remote host. (code: StatusCode(-1))\n","caller":"webSocket.readJsonData"}
-{"level":"info","timestamp":"2025-04-24T21:05:06.200","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T21:05:07.645","msg":"70907 datapoint imported in 1.4269942s","caller":"dmbHandler.NewDmbHandler"}
-{"level":"info","timestamp":"2025-04-24T21:05:07.646","msg":"https listen on 8101","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T21:05:07.646","msg":"http listen on 8100","caller":"main"}
-{"level":"error","timestamp":"2025-04-24T21:05:47.723","msg":"error GetIDFromQuery: id missing","caller":"dbmHandler.webSocket.Websocket"}
-{"level":"error","timestamp":"2025-04-24T21:06:41.071","msg":"error GetIDFromQuery: id missing","caller":"dbmHandler.webSocket.Websocket"}
-{"level":"error","timestamp":"2025-04-24T21:07:03.574","msg":"error GetIDFromQuery: id missing","caller":"dbmHandler.webSocket.Websocket"}
-{"level":"error","timestamp":"2025-04-24T21:07:20.319","msg":"error GetIDFromQuery: id missing","caller":"dbmHandler.webSocket.Websocket"}
-{"level":"info","timestamp":"2025-04-24T21:12:41.436","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T21:12:42.814","msg":"70907 datapoint imported in 1.3713767s","caller":"dmbHandler.NewDmbHandler"}
-{"level":"info","timestamp":"2025-04-24T21:12:42.816","msg":"https listen on 8101","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T21:12:42.816","msg":"http listen on 8100","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T21:14:12.004","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T21:14:13.145","msg":"70907 datapoint imported in 1.1323784s","caller":"dmbHandler.NewDmbHandler"}
-{"level":"info","timestamp":"2025-04-24T21:14:13.147","msg":"https listen on 8101","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T21:14:13.147","msg":"http listen on 8100","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T21:19:10.003","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T21:19:11.118","msg":"70907 datapoint imported in 1.1069385s","caller":"dmbHandler.NewDmbHandler"}
-{"level":"info","timestamp":"2025-04-24T21:19:11.120","msg":"https listen on 8101","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T21:19:11.120","msg":"http listen on 8100","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T22:16:43.417","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T22:16:44.736","msg":"70907 datapoint imported in 1.3123902s","caller":"dmbHandler.NewDmbHandler"}
-{"level":"info","timestamp":"2025-04-24T22:16:44.737","msg":"https listen on 8101","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T22:16:44.737","msg":"http listen on 8100","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T22:20:52.266","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T22:20:53.515","msg":"70907 datapoint imported in 1.2422894s","caller":"dmbHandler.NewDmbHandler"}
-{"level":"info","timestamp":"2025-04-24T22:20:53.516","msg":"https listen on 8101","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T22:20:53.516","msg":"http listen on 8100","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T22:23:40.476","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T22:23:44.389","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T22:24:00.215","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T22:24:02.022","msg":"70907 datapoint imported in 1.7927614s","caller":"dmbHandler.NewDmbHandler"}
-{"level":"info","timestamp":"2025-04-24T22:24:02.024","msg":"https listen on 8101","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T22:24:02.024","msg":"http listen on 8100","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T22:25:40.901","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T22:25:42.278","msg":"70907 datapoint imported in 1.3679863s","caller":"dmbHandler.NewDmbHandler"}
-{"level":"info","timestamp":"2025-04-24T22:25:42.280","msg":"https listen on 8101","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T22:25:42.280","msg":"http listen on 8100","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T22:26:33.502","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T22:26:34.850","msg":"70907 datapoint imported in 1.3400612s","caller":"dmbHandler.NewDmbHandler"}
-{"level":"info","timestamp":"2025-04-24T22:26:34.852","msg":"https listen on 8101","caller":"main"}
-{"level":"info","timestamp":"2025-04-24T22:26:34.852","msg":"http listen on 8100","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T07:10:44.651","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T07:10:45.573","msg":"70907 datapoint imported in 914.6413ms","caller":"dmbHandler.NewDmbHandler"}
-{"level":"info","timestamp":"2025-04-25T07:10:45.574","msg":"https listen on 8101","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T07:10:45.574","msg":"http listen on 8100","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T07:11:44.453","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T07:11:45.361","msg":"70907 datapoint imported in 899.9752ms","caller":"dmbHandler.NewDmbHandler"}
-{"level":"info","timestamp":"2025-04-25T07:11:45.362","msg":"https listen on 8101","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T07:11:45.362","msg":"http listen on 8100","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T07:12:16.822","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T07:12:17.727","msg":"70907 datapoint imported in 899.1678ms","caller":"dmbHandler.NewDmbHandler"}
-{"level":"info","timestamp":"2025-04-25T07:12:17.728","msg":"https listen on 8101","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T07:12:17.728","msg":"http listen on 8100","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T07:17:24.330","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T07:17:25.250","msg":"70907 datapoint imported in 911.9596ms","caller":"dmbHandler.NewDmbHandler"}
-{"level":"info","timestamp":"2025-04-25T07:17:25.251","msg":"https listen on 8101","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T07:17:25.251","msg":"http listen on 8100","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T08:25:32.926","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T08:25:33.921","msg":"70907 datapoint imported in 986.1125ms","caller":"dmbHandler.NewDmbHandler"}
-{"level":"info","timestamp":"2025-04-25T08:25:33.922","msg":"https listen on 8101","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T08:25:33.922","msg":"http listen on 8100","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T08:27:16.655","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T08:27:17.684","msg":"70907 datapoint imported in 1.0210028s","caller":"dmbHandler.NewDmbHandler"}
-{"level":"info","timestamp":"2025-04-25T08:27:17.686","msg":"https listen on 8101","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T08:27:17.686","msg":"http listen on 8100","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T08:30:55.958","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T08:30:56.908","msg":"70907 datapoint imported in 943.4574ms","caller":"dmbHandler.NewDmbHandler"}
-{"level":"info","timestamp":"2025-04-25T08:30:56.909","msg":"https listen on 8101","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T08:30:56.909","msg":"http listen on 8100","caller":"main"}
-{"level":"error","timestamp":"2025-04-25T08:33:01.191","msg":"WebSocket read error: failed to read JSON message: failed to get reader: failed to read frame header: read tcp 127.0.0.1:8100->127.0.0.1:56377: wsarecv: An existing connection was forcibly closed by the remote host. (code: StatusCode(-1))\n","caller":"webSocket.readJsonData"}
-{"level":"error","timestamp":"2025-04-25T08:33:54.415","msg":"WebSocket read error: failed to read JSON message: failed to unmarshal JSON: invalid character 't' after object key (code: StatusCode(-1))\n","caller":"webSocket.readJsonData"}
-{"level":"info","timestamp":"2025-04-25T09:05:51.134","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T09:05:52.070","msg":"70906 datapoint imported in 928.9406ms","caller":"dmbHandler.NewDmbHandler"}
-{"level":"info","timestamp":"2025-04-25T09:05:52.070","msg":"https listen on 8101","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T09:05:52.070","msg":"http listen on 8100","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T09:07:02.361","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T09:07:03.273","msg":"70906 datapoint imported in 905.3446ms","caller":"dmbHandler.NewDmbHandler"}
-{"level":"info","timestamp":"2025-04-25T09:07:03.274","msg":"https listen on 8101","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T09:07:03.274","msg":"http listen on 8100","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T09:08:58.495","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T09:08:59.563","msg":"70906 datapoint imported in 1.0605929s","caller":"dmbHandler.NewDmbHandler"}
-{"level":"info","timestamp":"2025-04-25T09:08:59.565","msg":"https listen on 8101","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T09:08:59.565","msg":"http listen on 8100","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T09:11:13.994","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T09:11:14.990","msg":"70906 datapoint imported in 988.5955ms","caller":"dmbHandler.NewDmbHandler"}
-{"level":"info","timestamp":"2025-04-25T09:11:15.009","msg":"https listen on 8101","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T09:11:15.009","msg":"http listen on 8100","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T09:12:10.501","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T09:12:11.497","msg":"70906 datapoint imported in 988.7645ms","caller":"dmbHandler.NewDmbHandler"}
-{"level":"info","timestamp":"2025-04-25T09:12:11.497","msg":"https listen on 8101","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T09:12:11.497","msg":"http listen on 8100","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T09:16:28.284","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T09:16:29.280","msg":"70906 datapoint imported in 989.4656ms","caller":"dmbHandler.NewDmbHandler"}
-{"level":"info","timestamp":"2025-04-25T09:16:29.282","msg":"https listen on 8101","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T09:16:29.282","msg":"http listen on 8100","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T09:18:38.809","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T09:18:39.792","msg":"70906 datapoint imported in 975.1616ms","caller":"dmbHandler.NewDmbHandler"}
-{"level":"info","timestamp":"2025-04-25T09:18:39.793","msg":"https listen on 8101","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T09:18:39.793","msg":"http listen on 8100","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T09:19:14.614","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T09:19:15.589","msg":"70906 datapoint imported in 967.5841ms","caller":"dmbHandler.NewDmbHandler"}
-{"level":"info","timestamp":"2025-04-25T09:19:15.590","msg":"https listen on 8101","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T09:19:15.590","msg":"http listen on 8100","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T09:20:13.787","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T09:20:14.802","msg":"70906 datapoint imported in 1.0079694s","caller":"dmbHandler.NewDmbHandler"}
-{"level":"info","timestamp":"2025-04-25T09:20:14.803","msg":"https listen on 8101","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T09:20:14.803","msg":"http listen on 8100","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T09:22:55.612","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T09:22:56.642","msg":"70906 datapoint imported in 1.0237716s","caller":"dmbHandler.NewDmbHandler"}
-{"level":"info","timestamp":"2025-04-25T09:22:56.644","msg":"https listen on 8101","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T09:22:56.644","msg":"http listen on 8100","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T11:56:04.487","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T11:56:54.839","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T11:57:19.923","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T11:58:34.896","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T11:59:18.942","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T12:01:11.727","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T12:01:46.005","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T12:01:46.807","msg":"70906 datapoint imported in 794.9182ms","caller":"dmbHandler.NewDmbHandler"}
-{"level":"info","timestamp":"2025-04-25T12:01:46.808","msg":"https listen on 8101","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T12:01:46.808","msg":"http listen on 8100","caller":"main"}
-{"level":"error","timestamp":"2025-04-25T12:03:27.661","msg":"WebSocket read error: failed to read JSON message: failed to get reader: failed to read frame header: read tcp 127.0.0.1:8100->127.0.0.1:58256: wsarecv: An existing connection was forcibly closed by the remote host. (code: StatusCode(-1))\n","caller":"webSocket.readJsonData"}
-{"level":"error","timestamp":"2025-04-25T12:05:06.726","msg":"WebSocket read error: failed to read JSON message: failed to get reader: context deadline exceeded (code: StatusCode(-1))\n","caller":"webSocket.readJsonData"}
-{"level":"error","timestamp":"2025-04-25T12:05:53.664","msg":"WebSocket read error: failed to read JSON message: failed to get reader: failed to read frame header: read tcp 127.0.0.1:8100->127.0.0.1:58285: wsarecv: An existing connection was forcibly closed by the remote host. (code: StatusCode(-1))\n","caller":"webSocket.readJsonData"}
-{"level":"info","timestamp":"2025-04-25T12:07:09.410","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T12:07:10.211","msg":"70906 datapoint imported in 792.3726ms","caller":"dmbHandler.NewDmbHandler"}
-{"level":"info","timestamp":"2025-04-25T12:07:10.213","msg":"https listen on 8101","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T12:07:10.213","msg":"http listen on 8100","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T12:08:37.247","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T12:08:38.103","msg":"70906 datapoint imported in 846.815ms","caller":"dmbHandler.NewDmbHandler"}
-{"level":"info","timestamp":"2025-04-25T12:08:38.105","msg":"https listen on 8101","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T12:08:38.105","msg":"http listen on 8100","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T12:09:19.425","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T12:09:20.262","msg":"70906 datapoint imported in 828.3318ms","caller":"dmbHandler.NewDmbHandler"}
-{"level":"info","timestamp":"2025-04-25T12:09:20.263","msg":"https listen on 8101","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T12:09:20.263","msg":"http listen on 8100","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T12:10:07.809","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T12:10:08.602","msg":"70906 datapoint imported in 784.836ms","caller":"dmbHandler.NewDmbHandler"}
-{"level":"info","timestamp":"2025-04-25T12:10:08.605","msg":"https listen on 8101","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T12:10:08.606","msg":"http listen on 8100","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T12:12:41.795","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T12:12:42.550","msg":"70906 datapoint imported in 748.8353ms","caller":"dmbHandler.NewDmbHandler"}
-{"level":"info","timestamp":"2025-04-25T12:12:42.551","msg":"https listen on 8101","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T12:12:42.551","msg":"http listen on 8100","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T13:12:03.575","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T13:12:04.428","msg":"70906 datapoint imported in 845.4047ms","caller":"dmbHandler.NewDmbHandler"}
-{"level":"info","timestamp":"2025-04-25T13:12:04.430","msg":"https listen on 8101","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T13:12:04.430","msg":"http listen on 8100","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T13:13:18.695","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T13:13:19.479","msg":"70906 datapoint imported in 775.076ms","caller":"dmbHandler.NewDmbHandler"}
-{"level":"info","timestamp":"2025-04-25T13:13:19.481","msg":"https listen on 8101","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T13:13:19.481","msg":"http listen on 8100","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T13:14:27.381","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T13:14:28.148","msg":"70906 datapoint imported in 761.1693ms","caller":"dmbHandler.NewDmbHandler"}
-{"level":"info","timestamp":"2025-04-25T13:14:28.149","msg":"https listen on 8101","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T13:14:28.149","msg":"http listen on 8100","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T13:15:24.104","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T13:15:24.891","msg":"70906 datapoint imported in 780.7757ms","caller":"dmbHandler.NewDmbHandler"}
-{"level":"info","timestamp":"2025-04-25T13:15:24.892","msg":"https listen on 8101","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T13:15:24.892","msg":"http listen on 8100","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T13:20:24.788","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T13:21:01.653","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T13:22:21.659","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T13:23:21.812","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T13:23:22.611","msg":"70906 datapoint imported in 792.0699ms","caller":"dmbHandler.NewDmbHandler"}
-{"level":"info","timestamp":"2025-04-25T13:23:22.612","msg":"https listen on 8101","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T13:23:22.612","msg":"http listen on 8100","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T17:09:23.012","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T17:09:23.821","msg":"70906 datapoint imported in 801.9546ms","caller":"dmbHandler.NewDmbHandler"}
-{"level":"info","timestamp":"2025-04-25T17:09:23.822","msg":"https listen on 8101","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T17:09:23.822","msg":"http listen on 8100","caller":"main"}
-{"level":"error","timestamp":"2025-04-25T17:16:40.059","msg":"WebSocket read error: failed to read JSON message: failed to get reader: failed to read frame header: read tcp 127.0.0.1:8100->127.0.0.1:60453: wsarecv: An existing connection was forcibly closed by the remote host. (code: StatusCode(-1))\n","caller":"webSocket.readJsonData"}
-{"level":"error","timestamp":"2025-04-25T17:17:30.460","msg":"WebSocket read error: failed to read JSON message: failed to get reader: failed to read frame header: read tcp 127.0.0.1:8100->127.0.0.1:60466: wsarecv: An existing connection was forcibly closed by the remote host. (code: StatusCode(-1))\n","caller":"webSocket.readJsonData"}
-{"level":"error","timestamp":"2025-04-25T17:18:11.705","msg":"WebSocket read error: failed to read JSON message: failed to get reader: failed to read frame header: read tcp 127.0.0.1:8100->127.0.0.1:60471: wsarecv: An existing connection was forcibly closed by the remote host. (code: StatusCode(-1))\n","caller":"webSocket.readJsonData"}
-{"level":"error","timestamp":"2025-04-25T17:18:37.346","msg":"WebSocket read error: failed to read JSON message: failed to get reader: failed to read frame header: read tcp 127.0.0.1:8100->127.0.0.1:60474: wsarecv: An existing connection was forcibly closed by the remote host. (code: StatusCode(-1))\n","caller":"webSocket.readJsonData"}
-{"level":"error","timestamp":"2025-04-25T17:19:19.728","msg":"WebSocket read error: failed to read JSON message: failed to get reader: failed to read frame header: read tcp 127.0.0.1:8100->127.0.0.1:60482: wsarecv: An existing connection was forcibly closed by the remote host. (code: StatusCode(-1))\n","caller":"webSocket.readJsonData"}
-{"level":"error","timestamp":"2025-04-25T17:20:41.498","msg":"WebSocket read error: failed to read JSON message: failed to get reader: failed to read frame header: read tcp 127.0.0.1:8100->127.0.0.1:60490: wsarecv: An existing connection was forcibly closed by the remote host. (code: StatusCode(-1))\n","caller":"webSocket.readJsonData"}
-{"level":"info","timestamp":"2025-04-25T17:21:31.964","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T17:21:32.684","msg":"70906 datapoint imported in 713.2521ms","caller":"dmbHandler.NewDmbHandler"}
-{"level":"info","timestamp":"2025-04-25T17:21:32.686","msg":"https listen on 8101","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T17:21:32.686","msg":"http listen on 8100","caller":"main"}
-{"level":"error","timestamp":"2025-04-25T17:21:50.922","msg":"WebSocket read error: failed to read JSON message: failed to get reader: failed to read frame header: read tcp 127.0.0.1:8100->127.0.0.1:60500: wsarecv: An existing connection was forcibly closed by the remote host. (code: StatusCode(-1))\n","caller":"webSocket.readJsonData"}
-{"level":"error","timestamp":"2025-04-25T17:40:12.968","msg":"WebSocket read error: failed to read JSON message: failed to get reader: failed to read frame header: read tcp 127.0.0.1:8100->127.0.0.1:60638: wsarecv: An existing connection was forcibly closed by the remote host. (code: StatusCode(-1))\n","caller":"webSocket.readJsonData"}
-{"level":"error","timestamp":"2025-04-25T17:41:10.660","msg":"WebSocket read error: failed to read JSON message: failed to get reader: failed to read frame header: read tcp 127.0.0.1:8100->127.0.0.1:60643: wsarecv: An existing connection was forcibly closed by the remote host. (code: StatusCode(-1))\n","caller":"webSocket.readJsonData"}
-{"level":"error","timestamp":"2025-04-25T17:42:37.316","msg":"WebSocket read error: failed to read JSON message: failed to get reader: failed to read frame header: read tcp 127.0.0.1:8100->127.0.0.1:60649: wsarecv: An existing connection was forcibly closed by the remote host. (code: StatusCode(-1))\n","caller":"webSocket.readJsonData"}
-{"level":"error","timestamp":"2025-04-25T17:43:12.558","msg":"WebSocket read error: failed to read JSON message: failed to get reader: failed to read frame header: read tcp 127.0.0.1:8100->127.0.0.1:60668: wsarecv: An existing connection was forcibly closed by the remote host. (code: StatusCode(-1))\n","caller":"webSocket.readJsonData"}
-{"level":"error","timestamp":"2025-04-25T17:45:58.700","msg":"WebSocket read error: failed to read JSON message: failed to get reader: context deadline exceeded (code: StatusCode(-1))\n","caller":"webSocket.readJsonData"}
-{"level":"error","timestamp":"2025-04-25T17:48:02.254","msg":"WebSocket read error: failed to read JSON message: failed to get reader: context deadline exceeded (code: StatusCode(-1))\n","caller":"webSocket.readJsonData"}
-{"level":"error","timestamp":"2025-04-25T17:48:48.574","msg":"WebSocket read error: failed to read JSON message: failed to get reader: failed to read frame header: read tcp 127.0.0.1:8100->127.0.0.1:60707: wsarecv: An existing connection was forcibly closed by the remote host. (code: StatusCode(-1))\n","caller":"webSocket.readJsonData"}
-{"level":"info","timestamp":"2025-04-25T17:48:51.929","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T17:48:52.816","msg":"70906 datapoint imported in 880.8198ms","caller":"dmbHandler.NewDmbHandler"}
-{"level":"info","timestamp":"2025-04-25T17:48:52.816","msg":"https listen on 8101","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T17:48:52.816","msg":"http listen on 8100","caller":"main"}
-{"level":"error","timestamp":"2025-04-25T17:49:45.093","msg":"WebSocket read error: failed to read JSON message: failed to get reader: received close frame: status = StatusInvalidFramePayloadData and reason = \"failed to unmarshal JSON\" (code: StatusInvalidFramePayloadData)\n","caller":"webSocket.readJsonData"}
-{"level":"info","timestamp":"2025-04-25T17:50:15.446","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T17:50:16.195","msg":"70906 datapoint imported in 742.7985ms","caller":"dmbHandler.NewDmbHandler"}
-{"level":"info","timestamp":"2025-04-25T17:50:16.195","msg":"https listen on 8101","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T17:50:16.195","msg":"http listen on 8100","caller":"main"}
-{"level":"error","timestamp":"2025-04-25T17:50:45.652","msg":"WebSocket read error: failed to read JSON message: failed to get reader: failed to read frame header: read tcp 127.0.0.1:8100->127.0.0.1:60741: wsarecv: An existing connection was forcibly closed by the remote host. (code: StatusCode(-1))\n","caller":"webSocket.readJsonData"}
-{"level":"info","timestamp":"2025-04-25T17:53:05.586","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T17:53:06.651","msg":"70906 datapoint imported in 1.0570504s","caller":"dmbHandler.NewDmbHandler"}
-{"level":"info","timestamp":"2025-04-25T17:53:06.655","msg":"https listen on 8101","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T17:53:06.655","msg":"http listen on 8100","caller":"main"}
-{"level":"error","timestamp":"2025-04-25T17:54:34.780","msg":"WebSocket read error: failed to read JSON message: failed to get reader: failed to read frame header: read tcp 127.0.0.1:8100->127.0.0.1:60795: wsarecv: An existing connection was forcibly closed by the remote host. (code: StatusCode(-1))\n","caller":"webSocket.readJsonData"}
-{"level":"info","timestamp":"2025-04-25T18:10:44.312","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T18:10:45.332","msg":"70906 datapoint imported in 1.0134914s","caller":"dmbHandler.NewDmbHandler"}
-{"level":"info","timestamp":"2025-04-25T18:10:45.335","msg":"https listen on 8101","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T18:10:45.335","msg":"http listen on 8100","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T18:13:20.722","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T18:13:22.194","msg":"70906 datapoint imported in 1.4611265s","caller":"dmbHandler.NewDmbHandler"}
-{"level":"info","timestamp":"2025-04-25T18:13:22.196","msg":"https listen on 8101","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T18:13:22.196","msg":"http listen on 8100","caller":"main"}
-{"level":"error","timestamp":"2025-04-25T18:13:57.021","msg":"WebSocket read error: failed to read JSON message: failed to get reader: failed to read frame header: read tcp 127.0.0.1:8100->127.0.0.1:60114: wsarecv: An existing connection was forcibly closed by the remote host. (code: StatusCode(-1))\n","caller":"webSocket.readJsonData"}
-{"level":"error","timestamp":"2025-04-25T18:14:36.932","msg":"WebSocket read error: failed to read JSON message: failed to get reader: failed to read frame header: read tcp 127.0.0.1:8100->127.0.0.1:60121: wsarecv: An existing connection was forcibly closed by the remote host. (code: StatusCode(-1))\n","caller":"webSocket.readJsonData"}
-{"level":"error","timestamp":"2025-04-25T18:18:10.065","msg":"WebSocket read error: failed to read JSON message: failed to get reader: failed to read frame header: read tcp 127.0.0.1:8100->127.0.0.1:60145: wsarecv: An existing connection was forcibly closed by the remote host. (code: StatusCode(-1))\n","caller":"webSocket.readJsonData"}
-{"level":"error","timestamp":"2025-04-25T18:18:38.801","msg":"WebSocket read error: failed to read JSON message: failed to get reader: failed to read frame header: read tcp 127.0.0.1:8100->127.0.0.1:60150: wsarecv: An existing connection was forcibly closed by the remote host. (code: StatusCode(-1))\n","caller":"webSocket.readJsonData"}
-{"level":"error","timestamp":"2025-04-25T18:20:42.312","msg":"WebSocket read error: failed to read JSON message: failed to get reader: failed to read frame header: read tcp 127.0.0.1:8100->127.0.0.1:60172: wsarecv: An existing connection was forcibly closed by the remote host. (code: StatusCode(-1))\n","caller":"webSocket.readJsonData"}
-{"level":"info","timestamp":"2025-04-25T18:21:03.724","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T18:21:04.929","msg":"70906 datapoint imported in 1.1963319s","caller":"dmbHandler.NewDmbHandler"}
-{"level":"info","timestamp":"2025-04-25T18:21:04.930","msg":"https listen on 8101","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T18:21:04.930","msg":"http listen on 8100","caller":"main"}
-{"level":"error","timestamp":"2025-04-25T18:21:15.257","msg":"WebSocket read error: failed to read JSON message: failed to get reader: failed to read frame header: read tcp 127.0.0.1:8100->127.0.0.1:60178: wsarecv: An existing connection was forcibly closed by the remote host. (code: StatusCode(-1))\n","caller":"webSocket.readJsonData"}
-{"level":"info","timestamp":"2025-04-25T18:22:19.764","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T18:22:20.997","msg":"70906 datapoint imported in 1.2254849s","caller":"dmbHandler.NewDmbHandler"}
-{"level":"info","timestamp":"2025-04-25T18:22:20.999","msg":"https listen on 8101","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T18:22:20.999","msg":"http listen on 8100","caller":"main"}
-{"level":"error","timestamp":"2025-04-25T18:22:35.605","msg":"WebSocket read error: failed to read JSON message: failed to get reader: failed to read frame header: read tcp 127.0.0.1:8100->127.0.0.1:60189: wsarecv: An existing connection was forcibly closed by the remote host. (code: StatusCode(-1))\n","caller":"webSocket.readJsonData"}
-{"level":"info","timestamp":"2025-04-25T18:25:03.634","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T18:25:04.696","msg":"70906 datapoint imported in 1.0560832s","caller":"dmbHandler.NewDmbHandler"}
-{"level":"info","timestamp":"2025-04-25T18:25:04.699","msg":"https listen on 8101","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T18:25:04.699","msg":"http listen on 8100","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T18:26:42.314","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T18:26:43.284","msg":"70906 datapoint imported in 961.4825ms","caller":"dmbHandler.NewDmbHandler"}
-{"level":"info","timestamp":"2025-04-25T18:26:43.285","msg":"http listen on 8100","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T18:26:43.285","msg":"https listen on 8101","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T18:29:02.744","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T18:29:03.951","msg":"70906 datapoint imported in 1.198078s","caller":"dmbHandler.NewDmbHandler"}
-{"level":"info","timestamp":"2025-04-25T18:29:03.953","msg":"https listen on 8101","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T18:29:03.953","msg":"http listen on 8100","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T18:30:19.122","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T18:30:20.174","msg":"70907 datapoint imported in 1.0439618s","caller":"dmbHandler.NewDmbHandler"}
-{"level":"info","timestamp":"2025-04-25T18:30:20.175","msg":"https listen on 8101","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T18:30:20.175","msg":"http listen on 8100","caller":"main"}
-{"level":"error","timestamp":"2025-04-25T18:30:33.182","msg":"WebSocket read error: failed to read JSON message: failed to get reader: failed to read frame header: read tcp 127.0.0.1:8100->127.0.0.1:60254: wsarecv: An existing connection was forcibly closed by the remote host. (code: StatusCode(-1))\n","caller":"webSocket.readJsonData"}
-{"level":"error","timestamp":"2025-04-25T18:31:52.116","msg":"WebSocket read error: failed to read JSON message: failed to get reader: failed to read frame header: read tcp 127.0.0.1:8100->127.0.0.1:60262: wsarecv: An existing connection was forcibly closed by the remote host. (code: StatusCode(-1))\n","caller":"webSocket.readJsonData"}
-{"level":"error","timestamp":"2025-04-25T18:33:49.944","msg":"WebSocket read error: failed to read JSON message: failed to get reader: failed to read frame header: read tcp 127.0.0.1:8100->127.0.0.1:60273: wsarecv: An existing connection was forcibly closed by the remote host. (code: StatusCode(-1))\n","caller":"webSocket.readJsonData"}
-{"level":"error","timestamp":"2025-04-25T18:35:43.555","msg":"WebSocket read error: failed to read JSON message: failed to get reader: failed to read frame header: read tcp 127.0.0.1:8100->127.0.0.1:60285: wsarecv: An existing connection was forcibly closed by the remote host. (code: StatusCode(-1))\n","caller":"webSocket.readJsonData"}
-{"level":"info","timestamp":"2025-04-25T18:39:48.869","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T18:39:49.961","msg":"70907 datapoint imported in 1.0772318s","caller":"dmbHandler.NewDmbHandler"}
-{"level":"info","timestamp":"2025-04-25T18:39:49.964","msg":"https listen on 8101","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T18:39:49.965","msg":"http listen on 8100","caller":"main"}
-{"level":"error","timestamp":"2025-04-25T18:41:04.179","msg":"WebSocket read error: failed to read JSON message: failed to get reader: failed to read frame header: read tcp 127.0.0.1:8100->127.0.0.1:60332: wsarecv: An existing connection was forcibly closed by the remote host. (code: StatusCode(-1))\n","caller":"webSocket.readJsonData"}
-{"level":"error","timestamp":"2025-04-25T18:41:51.029","msg":"WebSocket read error: failed to read JSON message: failed to get reader: failed to read frame header: read tcp 127.0.0.1:8100->127.0.0.1:60338: wsarecv: An existing connection was forcibly closed by the remote host. (code: StatusCode(-1))\n","caller":"webSocket.readJsonData"}
-{"level":"info","timestamp":"2025-04-25T18:43:21.868","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T18:43:23.055","msg":"70907 datapoint imported in 1.1785275s","caller":"dmbHandler.NewDmbHandler"}
-{"level":"info","timestamp":"2025-04-25T18:43:23.055","msg":"https listen on 8101","caller":"main"}
-{"level":"info","timestamp":"2025-04-25T18:43:23.055","msg":"http listen on 8100","caller":"main"}
-{"level":"error","timestamp":"2025-04-25T18:43:35.371","msg":"WebSocket read error: failed to read JSON message: failed to get reader: failed to read frame header: read tcp 127.0.0.1:8100->127.0.0.1:60375: wsarecv: An existing connection was forcibly closed by the remote host. (code: StatusCode(-1))\n","caller":"webSocket.readJsonData"}
-{"level":"error","timestamp":"2025-04-25T18:45:03.461","msg":"WebSocket read error: failed to read JSON message: failed to get reader: failed to read frame header: read tcp 127.0.0.1:8100->127.0.0.1:60383: wsarecv: An existing connection was forcibly closed by the remote host. (code: StatusCode(-1))\n","caller":"webSocket.readJsonData"}
-{"level":"error","timestamp":"2025-04-25T18:45:11.765","msg":"WebSocket read error: failed to read JSON message: failed to get reader: failed to read frame header: read tcp 127.0.0.1:8100->127.0.0.1:60387: wsarecv: An existing connection was forcibly closed by the remote host. (code: StatusCode(-1))\n","caller":"webSocket.readJsonData"}
-{"level":"error","timestamp":"2025-04-25T18:46:50.227","msg":"WebSocket read error: failed to read JSON message: failed to get reader: failed to read frame header: read tcp 127.0.0.1:8100->127.0.0.1:60392: wsarecv: An existing connection was forcibly closed by the remote host. (code: StatusCode(-1))\n","caller":"webSocket.readJsonData"}
-{"level":"info","timestamp":"2025-04-28T07:07:01.993","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-28T07:07:02.988","msg":"70907 datapoint imported in 987.5445ms","caller":"dmbHandler.NewDmbHandler"}
-{"level":"info","timestamp":"2025-04-28T07:07:02.989","msg":"https listen on 8101","caller":"main"}
-{"level":"info","timestamp":"2025-04-28T07:07:02.989","msg":"http listen on 8100","caller":"main"}
-{"level":"info","timestamp":"2025-04-28T07:08:36.247","msg":"WebSocket closed: failed to read JSON message: failed to get reader: received close frame: status = StatusNoStatusRcvd and reason = \"\" (code: StatusNoStatusRcvd)\n","caller":"webSocket.readJsonData"}
-{"level":"error","timestamp":"2025-04-28T07:08:42.204","msg":"WebSocket read error: failed to read JSON message: failed to get reader: failed to read frame header: read tcp 127.0.0.1:8100->127.0.0.1:52468: wsarecv: An existing connection was forcibly closed by the remote host. (code: StatusCode(-1))\n","caller":"webSocket.readJsonData"}
-{"level":"info","timestamp":"2025-04-28T07:09:43.158","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-28T07:09:44.206","msg":"70907 datapoint imported in 1.0379535s","caller":"dmbHandler.NewDmbHandler"}
-{"level":"info","timestamp":"2025-04-28T07:09:44.208","msg":"https listen on 8101","caller":"main"}
-{"level":"info","timestamp":"2025-04-28T07:09:44.208","msg":"http listen on 8100","caller":"main"}
-{"level":"error","timestamp":"2025-04-28T07:12:48.948","msg":"WebSocket read error: failed to read JSON message: failed to get reader: context deadline exceeded (code: StatusCode(-1))\n","caller":"webSocket.readJsonData"}
-{"level":"error","timestamp":"2025-04-28T07:16:13.566","msg":"WebSocket read error: failed to read JSON message: failed to unmarshal JSON: invalid character ';' after object key (code: StatusCode(-1))\n","caller":"webSocket.readJsonData"}
-{"level":"error","timestamp":"2025-04-28T07:17:20.409","msg":"WebSocket read error: failed to read JSON message: failed to get reader: failed to read frame header: read tcp 127.0.0.1:8100->127.0.0.1:52546: wsarecv: An existing connection was forcibly closed by the remote host. (code: StatusCode(-1))\n","caller":"webSocket.readJsonData"}
-{"level":"info","timestamp":"2025-04-28T07:23:23.492","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-28T07:23:23.501","msg":"3 datapoint imported in 0s","caller":"dmbHandler.NewDmbHandler"}
-{"level":"info","timestamp":"2025-04-28T07:23:23.505","msg":"https listen on 8101","caller":"main"}
-{"level":"info","timestamp":"2025-04-28T07:23:23.505","msg":"http listen on 8100","caller":"main"}
-{"level":"info","timestamp":"2025-04-28T07:28:11.405","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-28T07:28:11.411","msg":"3 datapoint imported in 613.1µs","caller":"dmbHandler.NewDmbHandler"}
-{"level":"info","timestamp":"2025-04-28T07:28:11.412","msg":"https listen on 8101","caller":"main"}
-{"level":"info","timestamp":"2025-04-28T07:28:11.412","msg":"http listen on 8100","caller":"main"}
-{"level":"info","timestamp":"2025-04-28T07:45:48.847","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-28T07:45:48.857","msg":"3 datapoint imported in 0s","caller":"dmbHandler.NewDmbHandler"}
-{"level":"info","timestamp":"2025-04-28T07:45:48.859","msg":"https listen on 8101","caller":"main"}
-{"level":"info","timestamp":"2025-04-28T07:45:48.859","msg":"http listen on 8100","caller":"main"}
-{"level":"error","timestamp":"2025-04-28T07:46:16.024","msg":"WebSocket read error: failed to read JSON message: failed to get reader: failed to read frame header: read tcp 127.0.0.1:8100->127.0.0.1:52947: wsarecv: An existing connection was forcibly closed by the remote host. (code: StatusCode(-1))\n","caller":"webSocket.readJsonData"}
-{"level":"info","timestamp":"2025-04-28T07:49:22.293","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-28T07:49:22.300","msg":"3 datapoint imported in 504.8µs","caller":"dmbHandler.NewDmbHandler"}
-{"level":"info","timestamp":"2025-04-28T07:49:22.301","msg":"https listen on 8101","caller":"main"}
-{"level":"info","timestamp":"2025-04-28T07:49:22.301","msg":"http listen on 8100","caller":"main"}
-{"level":"info","timestamp":"2025-04-28T07:52:36.070","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-28T07:52:36.079","msg":"3 datapoint imported in 805.4µs","caller":"dmbHandler.NewDmbHandler"}
-{"level":"info","timestamp":"2025-04-28T07:52:36.080","msg":"https listen on 8101","caller":"main"}
-{"level":"info","timestamp":"2025-04-28T07:52:36.080","msg":"http listen on 8100","caller":"main"}
-{"level":"info","timestamp":"2025-04-28T07:55:25.033","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-28T07:55:25.039","msg":"3 datapoint imported in 0s","caller":"dmbHandler.NewDmbHandler"}
-{"level":"info","timestamp":"2025-04-28T07:55:25.040","msg":"https listen on 8101","caller":"main"}
-{"level":"info","timestamp":"2025-04-28T07:55:25.040","msg":"http listen on 8100","caller":"main"}
-{"level":"info","timestamp":"2025-04-28T07:56:00.576","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-28T07:56:00.585","msg":"3 datapoint imported in 0s","caller":"dmbHandler.NewDmbHandler"}
-{"level":"info","timestamp":"2025-04-28T07:56:00.586","msg":"https listen on 8101","caller":"main"}
-{"level":"info","timestamp":"2025-04-28T07:56:00.586","msg":"http listen on 8100","caller":"main"}
-{"level":"info","timestamp":"2025-04-28T07:56:20.143","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-28T07:56:20.155","msg":"3 datapoint imported in 0s","caller":"dmbHandler.NewDmbHandler"}
-{"level":"info","timestamp":"2025-04-28T07:56:20.157","msg":"https listen on 8101","caller":"main"}
-{"level":"info","timestamp":"2025-04-28T07:56:20.157","msg":"http listen on 8100","caller":"main"}
-{"level":"info","timestamp":"2025-04-28T07:59:53.072","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-28T07:59:54.150","msg":"70907 datapoint imported in 1.0687481s","caller":"dmbHandler.NewDmbHandler"}
-{"level":"info","timestamp":"2025-04-28T07:59:54.151","msg":"https listen on 8101","caller":"main"}
-{"level":"info","timestamp":"2025-04-28T07:59:54.151","msg":"http listen on 8100","caller":"main"}
-{"level":"error","timestamp":"2025-04-28T08:02:15.702","msg":"WebSocket read error: failed to read JSON message: failed to get reader: failed to read frame header: read tcp 127.0.0.1:8100->127.0.0.1:53172: wsarecv: An existing connection was forcibly closed by the remote host. (code: StatusCode(-1))\n","caller":"webSocket.readJsonData"}
-{"level":"error","timestamp":"2025-04-28T08:03:05.908","msg":"WebSocket read error: failed to read JSON message: failed to get reader: context deadline exceeded (code: StatusCode(-1))\n","caller":"webSocket.readJsonData"}
-{"level":"error","timestamp":"2025-04-28T08:03:52.274","msg":"WebSocket read error: failed to read JSON message: failed to get reader: failed to read frame header: read tcp 127.0.0.1:8100->127.0.0.1:53205: wsarecv: An existing connection was forcibly closed by the remote host. (code: StatusCode(-1))\n","caller":"webSocket.readJsonData"}
-{"level":"error","timestamp":"2025-04-28T08:04:17.582","msg":"WebSocket read error: failed to read JSON message: failed to get reader: failed to read frame header: read tcp 127.0.0.1:8100->127.0.0.1:53211: wsarecv: An existing connection was forcibly closed by the remote host. (code: StatusCode(-1))\n","caller":"webSocket.readJsonData"}
-{"level":"info","timestamp":"2025-04-28T08:07:12.339","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-28T08:07:13.304","msg":"70907 datapoint imported in 958.7766ms","caller":"dmbHandler.NewDmbHandler"}
-{"level":"info","timestamp":"2025-04-28T08:07:13.304","msg":"https listen on 8101","caller":"main"}
-{"level":"info","timestamp":"2025-04-28T08:07:13.304","msg":"http listen on 8100","caller":"main"}
-{"level":"error","timestamp":"2025-04-28T08:07:26.521","msg":"WebSocket read error: failed to read JSON message: failed to get reader: failed to read frame header: read tcp 127.0.0.1:8100->127.0.0.1:53246: wsarecv: An existing connection was forcibly closed by the remote host. (code: StatusCode(-1))\n","caller":"webSocket.readJsonData"}
-{"level":"info","timestamp":"2025-04-28T17:45:43.538","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-28T17:45:44.528","msg":"70907 datapoint imported in 982.6566ms","caller":"dmbHandler.NewDmbHandler"}
-{"level":"info","timestamp":"2025-04-28T17:45:44.528","msg":"https listen on 8101","caller":"main"}
-{"level":"info","timestamp":"2025-04-28T17:45:44.528","msg":"http listen on 8100","caller":"main"}
-{"level":"error","timestamp":"2025-04-28T17:45:53.885","msg":"WebSocket read error: failed to read JSON message: failed to get reader: failed to read frame header: read tcp 127.0.0.1:8100->127.0.0.1:65143: wsarecv: An existing connection was forcibly closed by the remote host. (code: StatusCode(-1))\n","caller":"webSocket.readJsonData"}
-{"level":"error","timestamp":"2025-04-28T17:46:21.883","msg":"WebSocket read error: failed to read JSON message: failed to get reader: failed to read frame header: read tcp 127.0.0.1:8100->127.0.0.1:65149: wsarecv: An existing connection was forcibly closed by the remote host. (code: StatusCode(-1))\n","caller":"webSocket.readJsonData"}
-{"level":"info","timestamp":"2025-04-28T17:47:50.257","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-28T17:47:51.060","msg":"70907 datapoint imported in 796.7003ms","caller":"dmbHandler.NewDmbHandler"}
-{"level":"info","timestamp":"2025-04-28T17:47:51.061","msg":"https listen on 8101","caller":"main"}
-{"level":"info","timestamp":"2025-04-28T17:47:51.061","msg":"http listen on 8100","caller":"main"}
-{"level":"error","timestamp":"2025-04-28T17:48:00.013","msg":"WebSocket read error: failed to read JSON message: failed to get reader: failed to read frame header: read tcp 127.0.0.1:8100->127.0.0.1:65170: wsarecv: An existing connection was forcibly closed by the remote host. (code: StatusCode(-1))\n","caller":"webSocket.readJsonData"}
-{"level":"info","timestamp":"2025-04-28T17:48:52.882","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-28T17:48:53.730","msg":"70907 datapoint imported in 842.8278ms","caller":"dmbHandler.NewDmbHandler"}
-{"level":"info","timestamp":"2025-04-28T17:48:53.731","msg":"https listen on 8101","caller":"main"}
-{"level":"info","timestamp":"2025-04-28T17:48:53.731","msg":"http listen on 8100","caller":"main"}
-{"level":"info","timestamp":"2025-04-28T17:49:28.036","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-28T17:49:28.825","msg":"70907 datapoint imported in 782.5554ms","caller":"dmbHandler.NewDmbHandler"}
-{"level":"info","timestamp":"2025-04-28T17:49:28.826","msg":"https listen on 8101","caller":"main"}
-{"level":"info","timestamp":"2025-04-28T17:49:28.826","msg":"http listen on 8100","caller":"main"}
-{"level":"error","timestamp":"2025-04-28T17:54:40.497","msg":"WebSocket read error: failed to read JSON message: failed to get reader: failed to read frame header: read tcp 127.0.0.1:8100->127.0.0.1:65239: wsarecv: An existing connection was forcibly closed by the remote host. (code: StatusCode(-1))\n","caller":"webSocket.readJsonData"}
-{"level":"error","timestamp":"2025-04-28T17:55:11.490","msg":"WebSocket read error: failed to read JSON message: failed to get reader: failed to read frame header: read tcp 127.0.0.1:8100->127.0.0.1:65259: wsarecv: An existing connection was forcibly closed by the remote host. (code: StatusCode(-1))\n","caller":"webSocket.readJsonData"}
-{"level":"error","timestamp":"2025-04-28T17:59:15.995","msg":"WebSocket read error: failed to read JSON message: failed to get reader: failed to read frame header: read tcp 127.0.0.1:8100->127.0.0.1:65267: wsarecv: An existing connection was forcibly closed by the remote host. (code: StatusCode(-1))\n","caller":"webSocket.readJsonData"}
-{"level":"info","timestamp":"2025-04-28T20:47:42.420","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-28T20:47:43.986","msg":"70907 datapoint imported in 1.5574372s","caller":"dmbHandler.NewDmbHandler"}
-{"level":"info","timestamp":"2025-04-28T20:47:43.990","msg":"https listen on 8101","caller":"main"}
-{"level":"info","timestamp":"2025-04-28T20:47:43.990","msg":"http listen on 8100","caller":"main"}
-{"level":"error","timestamp":"2025-04-28T20:51:02.307","msg":"WebSocket read error: failed to read JSON message: failed to get reader: context deadline exceeded (code: StatusCode(-1))\n","caller":"webSocket.readJsonData"}
-{"level":"info","timestamp":"2025-04-28T20:56:52.360","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-28T20:56:53.533","msg":"70907 datapoint imported in 1.1662469s","caller":"dmbHandler.NewDmbHandler"}
-{"level":"info","timestamp":"2025-04-28T20:56:53.535","msg":"https listen on 8101","caller":"main"}
-{"level":"info","timestamp":"2025-04-28T20:56:53.535","msg":"http listen on 8100","caller":"main"}
-{"level":"error","timestamp":"2025-04-28T21:20:39.790","msg":"WebSocket read error: failed to read JSON message: failed to get reader: context deadline exceeded (code: StatusCode(-1))\n","caller":"webSocket.readJsonData"}
-{"level":"info","timestamp":"2025-04-28T21:33:04.705","msg":"start dma handler","caller":"main"}
-{"level":"info","timestamp":"2025-04-28T21:33:05.936","msg":"70907 datapoint imported in 1.2248659s","caller":"dmbHandler.NewDmbHandler"}
-{"level":"info","timestamp":"2025-04-28T21:33:05.939","msg":"https listen on 8101","caller":"main"}
-{"level":"info","timestamp":"2025-04-28T21:33:05.939","msg":"http listen on 8100","caller":"main"}
-{"level":"error","timestamp":"2025-04-28T21:36:40.240","msg":"WebSocket read error: failed to read JSON message: failed to get reader: context deadline exceeded (code: StatusCode(-1))\n","caller":"webSocket.readJsonData"}
-{"level":"error","timestamp":"2025-04-28T21:40:06.328","msg":"WebSocket read error: failed to read JSON message: failed to get reader: failed to read frame header: read tcp 127.0.0.1:8100->127.0.0.1:63981: wsarecv: An existing connection was forcibly closed by the remote host. (code: StatusCode(-1))\n","caller":"webSocket.readJsonData"}
-{"level":"error","timestamp":"2025-04-28T21:40:55.826","msg":"WebSocket read error: failed to read JSON message: failed to get reader: failed to read frame header: read tcp 127.0.0.1:8100->127.0.0.1:64037: wsarecv: An existing connection was forcibly closed by the remote host. (code: StatusCode(-1))\n","caller":"webSocket.readJsonData"}
-{"level":"error","timestamp":"2025-04-28T21:45:48.901","msg":"WebSocket read error: failed to read JSON message: failed to get reader: failed to read frame header: read tcp 127.0.0.1:8100->127.0.0.1:64148: wsarecv: An existing connection was forcibly closed by the remote host. (code: StatusCode(-1))\n","caller":"webSocket.readJsonData"}

go.mod

@@ -6,7 +6,7 @@ require (
 	github.com/coder/websocket v1.8.13
 	github.com/gin-gonic/gin v1.10.0
 	github.com/google/uuid v1.6.0
-	github.com/tecamino/tecamino-json_data v0.0.10
+	github.com/tecamino/tecamino-json_data v0.0.13
 	github.com/tecamino/tecamino-logger v0.2.0
 )
 

go.sum

@@ -63,8 +63,8 @@ github.com/stretchr/testify v1.8.1/go.mod h1:w2LPCIKwWwSfY2zedu0+kehJoqGctiVI29o
 github.com/stretchr/testify v1.8.4/go.mod h1:sz/lmYIOXD/1dqDmKjjqLyZ2RngseejIcXlSw2iwfAo=
 github.com/stretchr/testify v1.9.0 h1:HtqpIVDClZ4nwg75+f6Lvsy/wHu+3BoSGCbBAcpTsTg=
 github.com/stretchr/testify v1.9.0/go.mod h1:r2ic/lqez/lEtzL7wO/rwa5dbSLXVDPFyf8C91i36aY=
-github.com/tecamino/tecamino-json_data v0.0.10 h1:I5xvJ8eRxX0QbMTuSHlAA16FQ8uE49OiCSsQ7Xjircc=
+github.com/tecamino/tecamino-json_data v0.0.13 h1:hugbmCgXXh0F7YQAEbbJYHkSdq1caejD7SajDiMs42I=
-github.com/tecamino/tecamino-json_data v0.0.10/go.mod h1:LLlyD7Wwqplb2BP4PeO86EokEcTRidlW5MwgPd1T2JY=
+github.com/tecamino/tecamino-json_data v0.0.13/go.mod h1:LLlyD7Wwqplb2BP4PeO86EokEcTRidlW5MwgPd1T2JY=
 github.com/tecamino/tecamino-logger v0.2.0 h1:NPH/Gg9qRhmVoW8b39i1eXu/LEftHc74nyISpcRG+XU=
 github.com/tecamino/tecamino-logger v0.2.0/go.mod h1:0M1E9Uei/qw3e3WA1x3lBo1eP3H5oeYE7GjYrMahnj8=
 github.com/twitchyliquid64/golang-asm v0.15.1 h1:SU5vSMR7hnwNxj24w34ZyCi/FmDZTkS4MhqMhdFk5YI=

main.go

@@ -13,10 +13,12 @@ func main() {
 	// cli arguments
 	a := args.Init()
 
+	// initiate new database manger
 	dbmHandler, err := dbm.NewDbmHandler(a)
 	if err != nil {
 		panic(err)
 	}
+	//save database after exeutabe ends
 	defer dbmHandler.SaveDb()
 
 	//initialize new server
@@ -29,21 +31,24 @@ func main() {
 	s.Routes.GET("/saveData", dbmHandler.SaveData)
 	s.Routes.POST("/json_data", dbmHandler.Json_Data)
 	s.Routes.DELETE("/json_data", dbmHandler.Delete)
-
 	s.Routes.GET("/", func(c *gin.Context) {
 		c.String(200, "DBM WebSocket Server is running!")
 	})
 
+	// start http server
 	go func() {
 		dbmHandler.Log.Info("main", fmt.Sprintf("http listen on %d", a.Port.Http))
-		// start http server
 		if err := s.ServeHttp(a.Port.Http); err != nil {
 			dbmHandler.Log.Error("main", "error http server "+err.Error())
 			panic(err)
 		}
 	}()
 
+	// start https server
 	dbmHandler.Log.Info("main", fmt.Sprintf("https listen on %d", a.Port.Https))
-	panic(s.ServeHttps(a.Port.Https, a.Cert))
+	if err := s.ServeHttps(a.Port.Https, a.Cert); err != nil {
+		dbmHandler.Log.Error("main", "error http server "+err.Error())
+		panic(err)
+	}
 
 }

models/datapoint.go

@@ -0,0 +1,408 @@
+package models
+
+import (
+	"errors"
+	"fmt"
+	"regexp"
+	"strings"
+	"time"
+
+	"github.com/google/uuid"
+	serverModels "github.com/tecamino/tecamino-dbm/server/models"
+	"github.com/tecamino/tecamino-dbm/utils"
+	json_data "github.com/tecamino/tecamino-json_data"
+	json_dataModels "github.com/tecamino/tecamino-json_data/models"
+)
+
+const (
+	OnCreate = "onCreate"
+	OnChange = "onChange"
+	OnDelete = "onDelete"
+)
+
+type Datapoint struct {
+	Datapoints     map[string]*Datapoint   `json:"-"`
+	Uuid           uuid.UUID               `json:"uuid"`
+	Path           string                  `json:"path"`
+	Value          any                     `json:"value,omitempty"`
+	CreateDateTime int64                   `json:"createDateTime,omitempty"`
+	UpdateDateTime int64                   `json:"updateDateTime,omitempty"`
+	Type           json_dataModels.Type    `json:"type"`
+	ReadWrite      json_dataModels.Rights  `json:"readWrite"`
+	Drivers        json_dataModels.Drivers `json:"drivers,omitempty"`
+	Subscriptions  Subscriptions           `json:"-"`
+}
+
+func (d *Datapoint) Set(path string, set json_dataModels.Set) (bool, error) {
+	var changed bool
+	if path != "" {
+		changed = true
+		d.Path = path
+	}
+
+	if set.Type != "" {
+		changed = true
+		d.Type = set.Type
+	}
+
+	if d.Type != "" {
+		if d.Value == nil && set.Value == nil {
+			changed = true
+			d.Value = d.Type.DefaultValue()
+		} else if d.Value != d.Type.ConvertValue(set.Value) {
+			changed = true
+			d.Value = d.Type.ConvertValue(set.Value)
+		}
+
+	}
+	if set.Rights != "" {
+		changed = true
+		d.ReadWrite = set.Rights.GetRights()
+	}
+
+	if changed {
+		d.UpdateDateTime = time.Now().UnixMilli()
+	}
+
+	if set.Driver == nil {
+		return changed, nil
+	}
+	if set.Driver.Type == "" {
+		return changed, errors.New("driver type missing")
+	}
+	if set.Driver.Bus == "" {
+		return changed, errors.New("driver bus name missing")
+	}
+
+	if d.Drivers == nil {
+		d.Drivers = json_dataModels.NewDrivers()
+	}
+	d.Drivers.AddDriver(set.Driver.Type, set.Driver.Bus, set.Driver.Address)
+	d.UpdateDateTime = time.Now().UnixMilli()
+
+	return changed, nil
+}
+
+func (d *Datapoint) GetValueUint64() uint64 {
+	return utils.Uint64From(d.Value)
+}
+
+func (d *Datapoint) CreateDatapoints(conns *serverModels.Connections, sets ...json_dataModels.Set) (created []json_dataModels.Set, uuids Uuids, err error) {
+	if len(sets) == 0 {
+		return
+	}
+
+	uuids = make(Uuids, 1)
+
+	for _, dp := range sets {
+		parts := strings.Split(dp.Path, ":")
+
+		current := d
+		for i, part := range parts {
+			if current.Datapoints == nil {
+				current.Datapoints = make(map[string]*Datapoint)
+			}
+
+			if i == len(parts)-1 {
+				// Leaf node: create or update datapoint
+				if existing, ok := current.Datapoints[part]; ok {
+					publish, err := existing.Set("", dp)
+					if err != nil {
+						return nil, nil, err
+					}
+					created = append(created, json_dataModels.Set{
+						Uuid:    existing.Uuid,
+						Path:    existing.Path,
+						Type:    existing.Type,
+						Value:   existing.Value,
+						Rights:  existing.ReadWrite,
+						Drivers: &existing.Drivers,
+						Updated: true,
+					})
+
+					if publish {
+						existing.Publish(conns, OnChange)
+					}
+				} else {
+					ndp := Datapoint{
+						Uuid:           uuid.New(),
+						CreateDateTime: time.Now().UnixMilli(),
+						Subscriptions:  InitSubscribtion(),
+					}
+					// Create new
+					current.Datapoints[part] = &ndp
+					publish, err := ndp.Set(strings.Join(parts, ":"), dp)
+					if err != nil {
+						return nil, nil, err
+					}
+					created = append(created, json_dataModels.Set{
+						Uuid:   ndp.Uuid,
+						Path:   ndp.Path,
+						Type:   ndp.Type,
+						Value:  ndp.Value,
+						Rights: ndp.ReadWrite,
+						Driver: dp.Driver,
+					})
+					if publish {
+						current.Publish(conns, OnChange)
+					}
+					//add uuid to flat map for faster lookuo
+					uuids[ndp.Uuid] = &ndp
+				}
+			}
+
+			// Traverse or create intermediate datapoints
+			if next, ok := current.Datapoints[part]; ok {
+				current = next
+			} else {
+				newDp := &Datapoint{
+					Uuid:           uuid.New(),
+					Path:           strings.Join(parts[:i+1], ":"),
+					Type:           json_dataModels.NONE,
+					CreateDateTime: time.Now().UnixMilli(),
+					UpdateDateTime: time.Now().UnixMilli(),
+					Subscriptions:  InitSubscribtion(),
+				}
+
+				created = append(created, json_dataModels.Set{
+					Uuid:   newDp.Uuid,
+					Path:   newDp.Path,
+					Type:   newDp.Type,
+					Value:  newDp.Value,
+					Rights: newDp.ReadWrite,
+				})
+
+				if dp.Rights != "" {
+					newDp.ReadWrite = dp.Rights.GetRights()
+				}
+
+				current.Datapoints[part] = newDp
+				current = newDp
+
+				//add uuid to flat map for faster lookuo
+				uuids[newDp.Uuid] = newDp
+			}
+		}
+	}
+	return
+}
+
+func (d *Datapoint) ImportDatapoint(conns *serverModels.Connections, dp Datapoint, path string) (uuids Uuids, err error) {
+	parts := strings.Split(dp.Path, ":")
+
+	uuids = make(Uuids, 1)
+
+	current := d
+	for i, part := range parts {
+		if current.Datapoints == nil {
+			current.Datapoints = make(map[string]*Datapoint)
+		}
+
+		if i == len(parts)-1 {
+			// Leaf node: import the datapoint
+			if existing, ok := current.Datapoints[part]; ok {
+				existing.Type = dp.Type
+				existing.Value = dp.Type.ConvertValue(dp.Value)
+				existing.ReadWrite = dp.ReadWrite.GetRights()
+				existing.UpdateDateTime = time.Now().UnixMilli()
+				dp.Publish(conns, OnChange)
+			} else {
+				dp.Path = strings.Join(parts, ":")
+				dp.ReadWrite = dp.ReadWrite.GetRights()
+				dp.UpdateDateTime = time.Now().UnixMilli()
+				dp.Subscriptions = InitSubscribtion()
+				current.Datapoints[part] = &dp
+				//add uuid to flat map for faster lookuo
+				uuids[dp.Uuid] = &dp
+				dp.Publish(conns, OnChange)
+			}
+
+			return uuids, nil
+		}
+
+		// Traverse or create intermediate nodes
+		if next, ok := current.Datapoints[part]; ok {
+			current = next
+		} else {
+			newDp := &Datapoint{
+				Path:           strings.Join(parts[:i+1], ":"),
+				Type:           json_dataModels.NONE,
+				ReadWrite:      dp.ReadWrite.GetRights(),
+				UpdateDateTime: time.Now().UnixMilli(),
+			}
+			newDp.ReadWrite = newDp.ReadWrite.GetRights()
+			current.Datapoints[part] = newDp
+			current = newDp
+			//add uuid to flat map for faster lookuo
+			uuids[newDp.Uuid] = newDp
+		}
+	}
+	return uuids, nil
+}
+
+func (d *Datapoint) UpdateDatapointValue(conns *serverModels.Connections, value any, path string) error {
+
+	paths := strings.Split(path, ":")
+
+	current := d
+	for i, part := range paths {
+		dp, ok := current.Datapoints[part]
+		if !ok {
+			return fmt.Errorf("datapoint path not found: %s (at %s)", path, part)
+		}
+		if i == len(paths)-1 {
+			dp.Value = dp.Type.ConvertValue(value)
+			dp.UpdateDateTime = time.Now().UnixMilli()
+			dp.Publish(conns, OnChange)
+			return nil
+		}
+		current = dp
+	}
+	return nil
+}
+
+func (d *Datapoint) UpdateValue(conns *serverModels.Connections, value any) error {
+	d.Value = d.Type.ConvertValue(value)
+	d.UpdateDateTime = time.Now().UnixMilli()
+	d.Publish(conns, OnChange)
+	return nil
+}
+
+func (d *Datapoint) RemoveDatapoint(conns *serverModels.Connections, set json_dataModels.Set) (json_dataModels.Set, error) {
+	parts := strings.Split(set.Path, ":")
+
+	if len(parts) < 1 {
+		return json_dataModels.Set{}, fmt.Errorf("invalid path: '%s'", set.Path)
+	}
+
+	current := d
+	for i := range len(parts) - 1 {
+		next, ok := current.Datapoints[parts[i]]
+		if !ok {
+			return json_dataModels.Set{}, fmt.Errorf("path not found: '%s'", strings.Join(parts[:i+1], ":"))
+		}
+		current = next
+	}
+
+	toDelete := parts[len(parts)-1]
+	if dp, ok := current.Datapoints[toDelete]; ok {
+		dp.Publish(conns, OnDelete)
+		delete(current.Datapoints, toDelete)
+		return json_dataModels.Set{
+			Uuid: set.Uuid,
+			Path: set.Path,
+		}, nil
+	}
+	return json_dataModels.Set{}, fmt.Errorf("datapoint '%s' not found", set.Path)
+}
+
+func (d *Datapoint) GetAllDatapoints(depth uint) (dps Datapoints) {
+
+	var dfs func(dp *Datapoint, currentDepth uint)
+	dfs = func(dp *Datapoint, currentDepth uint) {
+		if depth == 1 {
+			return
+		} else if depth == 0 {
+			// Return all descendants
+			for _, child := range dp.Datapoints {
+				dps = append(dps, child)
+				dfs(child, currentDepth+1)
+			}
+			return
+		}
+
+		if currentDepth == depth-1 {
+			return
+		}
+
+		for _, child := range dp.Datapoints {
+			dps = append(dps, child)
+			dfs(child, currentDepth+1)
+		}
+	}
+	dps = append(dps, d)
+	dfs(d, 0)
+	dps.SortSlice()
+	return
+}
+
+func (d *Datapoint) QueryDatapoints(depth uint, path string) (dps Datapoints) {
+	parts := strings.Split(path, ":")
+
+	var dfs func(current *Datapoint, index int)
+	dfs = func(current *Datapoint, index int) {
+
+		if index == len(parts) {
+			dps = append(dps, current.GetAllDatapoints(depth)...)
+			return
+		}
+
+		pattern := "^" + parts[index] + "$"
+		re, err := regexp.Compile(pattern)
+		if err != nil {
+			return
+		}
+
+		for name, dp := range current.Datapoints {
+			if re.MatchString(name) {
+				dfs(dp, index+1)
+			}
+		}
+	}
+
+	dfs(d, 0)
+	dps.SortSlice()
+	return
+}
+
+func (d *Datapoint) AddSubscribtion(id string, sub json_dataModels.Subscription) {
+	if d.Subscriptions == nil {
+		return
+	}
+
+	if s, ok := d.Subscriptions[id]; ok {
+		s.OnCreate = sub.OnCreate
+		s.OnChange = sub.OnChange
+		s.OnDelete = sub.OnDelete
+	} else {
+		d.Subscriptions[id] = &Subscription{
+			OnCreate: sub.OnCreate,
+			OnChange: sub.OnChange,
+			OnDelete: sub.OnDelete,
+		}
+	}
+}
+
+func (d *Datapoint) RemoveSubscribtion(id string) {
+	if _, ok := d.Subscriptions[id]; !ok {
+		return
+	}
+	delete(d.Subscriptions, id)
+}
+
+func (d *Datapoint) Publish(conns *serverModels.Connections, eventType string) error {
+	if conns.Clients == nil {
+		return nil
+	}
+	conns.RLock()
+	defer conns.RUnlock()
+
+	for id := range d.Subscriptions {
+		if _, ok := conns.Clients[id]; !ok {
+			delete(d.Subscriptions, id)
+		} else {
+			r := json_data.NewResponse()
+			r.AddUPublish(json_dataModels.Publish{
+				Event: eventType,
+				Uuid:  d.Uuid,
+				Path:  d.Path,
+				Value: d.Value,
+			})
+
+			if err := conns.SendResponse(id, r); err != nil {
+				return err
+			}
+		}
+	}
+	return nil
+}

models/datapoints.go

@@ -1,384 +1,12 @@
 package models
 
-import (
+import "sort"
-	"errors"
-	"fmt"
-	"regexp"
-	"strings"
-	"time"
 
-	"github.com/coder/websocket/wsjson"
+type Datapoints []*Datapoint
-	"github.com/google/uuid"
-	serverModels "github.com/tecamino/tecamino-dbm/server/models"
-	"github.com/tecamino/tecamino-dbm/utils"
-	json_data "github.com/tecamino/tecamino-json_data"
-	json_dataModels "github.com/tecamino/tecamino-json_data/models"
-)
 
-const (
+func (d *Datapoints) SortSlice() {
-	OnCreate = "onCreate"
+	// Sort by Path before processing
-	OnChange = "onChange"
+	sort.Slice(*d, func(i, j int) bool {
-	OnDelete = "onDelete"
+		return (*d)[i].Path < (*d)[j].Path
-)
-
-type Datapoint struct {
-	Datapoints     map[string]*Datapoint   `json:"-"`
-	Uuid           uuid.UUID               `json:"uuid"`
-	Path           string                  `json:"path"`
-	Value          any                     `json:"value,omitempty"`
-	CreateDateTime int64                   `json:"createDateTime,omitempty"`
-	UpdateDateTime int64                   `json:"updateDateTime,omitempty"`
-	Type           json_dataModels.Type    `json:"type"`
-	ReadWrite      json_dataModels.Rights  `json:"readWrite"`
-	Drivers        json_dataModels.Drivers `json:"drivers,omitempty"`
-	Subscriptions  Subscriptions           `json:"-"`
-}
-
-func (d *Datapoint) Set(path string, set json_dataModels.Set) (bool, error) {
-	var changed bool
-	if path != "" {
-		changed = true
-		d.Path = path
-	}
-
-	if set.Type != "" {
-		changed = true
-		d.Type = set.Type
-	}
-
-	if d.Type != "" {
-		if d.Value == nil && set.Value == nil {
-			changed = true
-			d.Value = d.Type.DefaultValue()
-		} else if d.Value != d.Type.ConvertValue(set.Value) {
-			changed = true
-			d.Value = d.Type.ConvertValue(set.Value)
-		}
-
-	}
-	if set.Rights != "" {
-		changed = true
-		d.ReadWrite = set.Rights.GetRights()
-	}
-
-	if changed {
-		d.UpdateDateTime = time.Now().UnixMilli()
-	}
-
-	if set.Driver == nil {
-		return changed, nil
-	}
-	if set.Driver.Type == "" {
-		return changed, errors.New("driver type missing")
-	}
-	if set.Driver.Bus == "" {
-		return changed, errors.New("driver bus name missing")
-	}
-
-	if d.Drivers == nil {
-		d.Drivers = json_dataModels.NewDrivers()
-	}
-	d.Drivers.AddDriver(set.Driver.Type, set.Driver.Bus, set.Driver.Address)
-	d.UpdateDateTime = time.Now().UnixMilli()
-
-	return changed, nil
-}
-
-func (d *Datapoint) GetValueUint64() uint64 {
-	return utils.Uint64From(d.Value)
-}
-
-func (d *Datapoint) CreateDatapoints(conns *serverModels.Connections, sets ...json_dataModels.Set) (created []json_dataModels.Set, err error) {
-	if len(sets) == 0 {
-		return
-	}
-	for _, dp := range sets {
-		parts := strings.Split(dp.Path, ":")
-
-		current := d
-		for i, part := range parts {
-			if current.Datapoints == nil {
-				current.Datapoints = make(map[string]*Datapoint)
-			}
-
-			if i == len(parts)-1 {
-				// Leaf node: create or update datapoint
-				if existing, ok := current.Datapoints[part]; ok {
-					publish, err := existing.Set("", dp)
-					if err != nil {
-						return nil, err
-					}
-					created = append(created, json_dataModels.Set{
-						Uuid:    existing.Uuid,
-						Path:    existing.Path,
-						Type:    existing.Type,
-						Value:   existing.Value,
-						Rights:  existing.ReadWrite,
-						Drivers: &existing.Drivers,
-						Updated: true,
 	})
-
-					if publish {
-						existing.Publish(conns, OnChange)
-					}
-				} else {
-					// Create new
-					current.Datapoints[part] = &Datapoint{
-						Uuid:           uuid.New(),
-						CreateDateTime: time.Now().UnixMilli(),
-						Subscriptions:  InitSubscribtion(),
-					}
-					publish, err := current.Datapoints[part].Set(strings.Join(parts, ":"), dp)
-					if err != nil {
-						return nil, err
-					}
-					created = append(created, json_dataModels.Set{
-						Uuid:   current.Uuid,
-						Path:   current.Path,
-						Type:   current.Type,
-						Value:  current.Value,
-						Rights: current.ReadWrite,
-						Driver: dp.Driver,
-					})
-					if publish {
-						current.Publish(conns, OnChange)
-					}
-				}
-			}
-
-			// Traverse or create intermediate datapoints
-			if next, ok := current.Datapoints[part]; ok {
-				current = next
-			} else {
-				newDp := &Datapoint{
-					Uuid:           uuid.New(),
-					Path:           strings.Join(parts[:i+1], ":"),
-					Type:           json_dataModels.NONE,
-					CreateDateTime: time.Now().UnixMilli(),
-					UpdateDateTime: time.Now().UnixMilli(),
-					Subscriptions:  InitSubscribtion(),
-				}
-
-				created = append(created, json_dataModels.Set{
-					Uuid:   newDp.Uuid,
-					Path:   newDp.Path,
-					Type:   newDp.Type,
-					Value:  newDp.Value,
-					Rights: newDp.ReadWrite,
-				})
-
-				if dp.Rights != "" {
-					newDp.ReadWrite = dp.Rights.GetRights()
-				}
-
-				current.Datapoints[part] = newDp
-				current = newDp
-			}
-		}
-	}
-	return
-}
-
-func (d *Datapoint) ImportDatapoint(conns *serverModels.Connections, dp Datapoint, path string) error {
-	parts := strings.Split(dp.Path, ":")
-
-	current := d
-	for i, part := range parts {
-		if current.Datapoints == nil {
-			current.Datapoints = make(map[string]*Datapoint)
-		}
-
-		if i == len(parts)-1 {
-			// Leaf node: import the datapoint
-			if existing, ok := current.Datapoints[part]; ok {
-				existing.Type = dp.Type
-				existing.Value = current.Type.ConvertValue(dp.Value)
-				existing.ReadWrite = dp.ReadWrite.GetRights()
-				existing.UpdateDateTime = time.Now().UnixMilli()
-				dp.Publish(conns, OnChange)
-			} else {
-				dp.Path = strings.Join(parts, ":")
-				dp.ReadWrite = dp.ReadWrite.GetRights()
-				dp.UpdateDateTime = time.Now().UnixMilli()
-				dp.Subscriptions = InitSubscribtion()
-				current.Datapoints[part] = &dp
-				dp.Publish(conns, OnChange)
-			}
-			return nil
-		}
-
-		// Traverse or create intermediate nodes
-		if next, ok := current.Datapoints[part]; ok {
-			current = next
-		} else {
-			newDp := &Datapoint{
-				Path:           strings.Join(parts[:i+1], ":"),
-				Type:           json_dataModels.NONE,
-				ReadWrite:      dp.ReadWrite.GetRights(),
-				UpdateDateTime: time.Now().UnixMilli(),
-			}
-			newDp.ReadWrite = newDp.ReadWrite.GetRights()
-			current.Datapoints[part] = newDp
-			current = newDp
-		}
-	}
-	return nil
-}
-
-func (d *Datapoint) UpdateDatapointValue(conns *serverModels.Connections, value any, path string) error {
-
-	paths := strings.Split(path, ":")
-
-	current := d
-	for i, part := range paths {
-		dp, ok := current.Datapoints[part]
-		if !ok {
-			return fmt.Errorf("datapoint path not found: %s (at %s)", path, part)
-		}
-		if i == len(paths)-1 {
-			dp.Value = dp.Type.ConvertValue(value)
-			dp.UpdateDateTime = time.Now().UnixMilli()
-			dp.Publish(conns, OnChange)
-			return nil
-		}
-		current = dp
-	}
-	return nil
-}
-
-func (d *Datapoint) RemoveDatapoint(conns *serverModels.Connections, set json_dataModels.Set) (json_dataModels.Set, error) {
-	parts := strings.Split(set.Path, ":")
-
-	if len(parts) < 1 {
-		return json_dataModels.Set{}, fmt.Errorf("invalid path: '%s'", set.Path)
-	}
-
-	current := d
-	for i := range len(parts) - 1 {
-		next, ok := current.Datapoints[parts[i]]
-		if !ok {
-			return json_dataModels.Set{}, fmt.Errorf("path not found: '%s'", strings.Join(parts[:i+1], ":"))
-		}
-		current = next
-	}
-
-	toDelete := parts[len(parts)-1]
-	if dp, ok := current.Datapoints[toDelete]; ok {
-		dp.Publish(conns, OnDelete)
-		delete(current.Datapoints, toDelete)
-		return json_dataModels.Set{
-			Uuid: set.Uuid,
-			Path: set.Path,
-		}, nil
-	}
-	return json_dataModels.Set{}, fmt.Errorf("datapoint '%s' not found", set.Path)
-}
-
-func (d *Datapoint) GetAllDatapoints(depth uint) (dps []*Datapoint) {
-
-	var dfs func(dp *Datapoint, currentDepth uint)
-	dfs = func(dp *Datapoint, currentDepth uint) {
-		if depth == 1 {
-			return
-		} else if depth == 0 {
-			// Return all descendants
-			for _, child := range dp.Datapoints {
-				dps = append(dps, child)
-				dfs(child, currentDepth+1)
-			}
-			return
-		}
-
-		if currentDepth == depth-1 {
-			return
-		}
-
-		for _, child := range dp.Datapoints {
-			dps = append(dps, child)
-			dfs(child, currentDepth+1)
-		}
-	}
-	dps = append(dps, d)
-	dfs(d, 0)
-	return
-}
-
-func (d *Datapoint) QueryDatapoints(depth uint, path string) (dps []*Datapoint) {
-	parts := strings.Split(path, ":")
-
-	var dfs func(current *Datapoint, index int)
-	dfs = func(current *Datapoint, index int) {
-
-		if index == len(parts) {
-			dps = append(dps, current.GetAllDatapoints(depth)...)
-			return
-		}
-
-		pattern := "^" + parts[index] + "$"
-		re, err := regexp.Compile(pattern)
-		if err != nil {
-			return
-		}
-
-		for name, dp := range current.Datapoints {
-			if re.MatchString(name) {
-				dfs(dp, index+1)
-			}
-		}
-	}
-
-	dfs(d, 0)
-	return
-}
-
-func (d *Datapoint) AddSubscribtion(id string, sub json_dataModels.Subscribe) {
-	if d.Subscriptions == nil {
-		return
-	}
-
-	if s, ok := d.Subscriptions[id]; ok {
-		s.OnCreate = sub.OnCreate
-		s.OnChange = sub.OnChange
-		s.OnDelete = sub.OnDelete
-	} else {
-		d.Subscriptions[id] = &Subscription{
-			OnCreate: sub.OnCreate,
-			OnChange: sub.OnChange,
-			OnDelete: sub.OnDelete,
-		}
-	}
-}
-
-func (d *Datapoint) RemoveSubscribtion(id string) {
-	if _, ok := d.Subscriptions[id]; !ok {
-		return
-	}
-	delete(d.Subscriptions, id)
-}
-
-func (d *Datapoint) Publish(conns *serverModels.Connections, eventType string) error {
-	if conns.Clients == nil {
-		return nil
-	}
-	conns.RLock()
-	defer conns.RUnlock()
-
-	for id := range d.Subscriptions {
-		if client, ok := conns.Clients[id]; !ok {
-			delete(d.Subscriptions, id)
-		} else {
-			r := json_data.NewResponse()
-			r.AddUPublish(json_dataModels.Publish{
-				Event: eventType,
-				Uuid:  d.Uuid,
-				Path:  d.Path,
-				Value: d.Value,
-			})
-			err := wsjson.Write(client.Ctx, client.Conn, r)
-			if err != nil {
-				return err
-			}
-		}
-	}
-	return nil
 }

models/dbm.go

@@ -0,0 +1,190 @@
+package models
+
+import (
+	"fmt"
+	"runtime"
+	"time"
+
+	"maps"
+
+	"github.com/google/uuid"
+	serverModels "github.com/tecamino/tecamino-dbm/server/models"
+	"github.com/tecamino/tecamino-dbm/utils"
+	json_dataModels "github.com/tecamino/tecamino-json_data/models"
+	"github.com/tecamino/tecamino-logger/logging"
+)
+
+type DBM struct {
+	Datapoints Datapoint
+	Uuids      Uuids
+	Conns      *serverModels.Connections
+	Log        *logging.Logger
+}
+
+var SystemDatapoints uuid.UUID
+
+func NewDBM(conns *serverModels.Connections, log *logging.Logger) *DBM {
+	return &DBM{
+		Datapoints: Datapoint{},
+		Uuids:      make(Uuids),
+		Conns:      conns,
+		Log:        log,
+	}
+}
+
+func (d *DBM) CreateDatapoints(sets ...json_dataModels.Set) ([]json_dataModels.Set, error) {
+	if len(sets) == 0 {
+		return nil, nil
+	}
+
+	dps, uuids, err := d.Datapoints.CreateDatapoints(d.Conns, sets...)
+
+	//save uuid in seperate map for fast look up
+	maps.Copy(d.Uuids, uuids)
+
+	if err != nil {
+		return nil, err
+	}
+
+	var ndp uint64
+	for _, dp := range dps {
+		if !dp.Updated {
+			ndp++
+		}
+	}
+
+	d.ModifyCountedDatapoints(ndp, false)
+	return dps, nil
+}
+
+func (d *DBM) ImportDatapoints(dps ...Datapoint) error {
+	for _, dp := range dps {
+		uuids, err := d.Datapoints.ImportDatapoint(d.Conns, dp, dp.Path)
+		if err != nil {
+			return err
+		}
+		maps.Copy(d.Uuids, uuids)
+
+		d.ModifyCountedDatapoints(1, false)
+	}
+	return nil
+}
+
+func (d *DBM) UpdateDatapointValue(value any, uid uuid.UUID, path ...string) error {
+	if uid != uuid.Nil {
+		if _, ok := d.Uuids[uid]; !ok {
+			return fmt.Errorf("uuid %s not found", uid.String())
+		}
+		dp := d.Uuids[uid]
+		dp.Value = dp.Type.ConvertValue(value)
+		dp.UpdateDateTime = time.Now().UnixMilli()
+		dp.Publish(d.Conns, OnChange)
+	}
+
+	if len(path) > 1 {
+		return fmt.Errorf("only one path allowed")
+	}
+
+	return d.Datapoints.UpdateDatapointValue(d.Conns, value, path[0])
+}
+
+func (d *DBM) RemoveDatapoint(sets ...json_dataModels.Set) ([]json_dataModels.Set, error) {
+	var lsRemoved []json_dataModels.Set
+	for _, set := range sets {
+		removed, err := d.Datapoints.RemoveDatapoint(d.Conns, set)
+		if err != nil {
+			return lsRemoved, err
+		}
+		lsRemoved = append(lsRemoved, removed)
+		d.ModifyCountedDatapoints(1, true)
+	}
+
+	return lsRemoved, nil
+}
+
+func (d *DBM) QueryDatapoints(depth uint, uid uuid.UUID, key ...string) []*Datapoint {
+	if uid != uuid.Nil {
+		if _, ok := d.Uuids[uid]; !ok {
+			return nil
+		}
+		dp := d.Uuids[uid]
+		dps := []*Datapoint{dp}
+		return append(dps, dp.QueryDatapoints(depth, key[0])...)
+	}
+	return d.Datapoints.QueryDatapoints(depth, key[0])
+}
+
+func (d *DBM) GetAllDatapoints(depth uint) (dps Datapoints) {
+	return d.Datapoints.GetAllDatapoints(0)
+}
+
+func (d *DBM) GetNumbersOfDatapoints() uint64 {
+	return utils.Uint64From(d.Datapoints.Datapoints["System"].Datapoints["Datapoints"].Value)
+}
+
+func (d *DBM) ModifyCountedDatapoints(count uint64, countDown bool) {
+	dp := d.QueryDatapoints(1, SystemDatapoints, "System:Datapoints")
+	amount := dp[0].GetValueUint64()
+	if countDown {
+		amount -= count
+	} else {
+		amount += count
+	}
+	d.UpdateDatapointValue(amount, SystemDatapoints, "System:Datapoints")
+}
+
+func (d *DBM) GoSystemTime() error {
+	path := "System:Time"
+	var tOld int64
+
+	typ := json_dataModels.STR
+	rights := json_dataModels.Read
+	_, err := d.CreateDatapoints(json_dataModels.Set{Path: path, Type: typ, Rights: rights})
+	if err != nil {
+		d.Log.Error("system.GoSystemTime", err.Error())
+		return err
+	}
+
+	go func() {
+		for {
+			t := time.Now().UnixMilli()
+			if tOld != t {
+				if er := d.UpdateDatapointValue(time.UnixMilli(t).Format("2006-01-02 15:04:05"), uuid.Nil, path); er != nil {
+					d.Log.Error("dmb.Handler.AddSystemDps.UpdateDatapointValue", er.Error())
+				}
+				tOld = t
+			}
+			time.Sleep(time.Second)
+		}
+	}()
+	return nil
+}
+
+func (d *DBM) GoSystemMemory() error {
+	path := "System:UsedMemory"
+	var m runtime.MemStats
+	var mOld uint64
+
+	typ := json_dataModels.STR
+	rights := json_dataModels.Read
+	_, err := d.CreateDatapoints(json_dataModels.Set{Path: path, Type: typ, Rights: rights})
+	if err != nil {
+		d.Log.Error("system.GoSystemMemory", err.Error())
+		return err
+	}
+
+	go func() {
+		for {
+			runtime.ReadMemStats(&m)
+			if m.Sys != mOld {
+				mem := fmt.Sprintf("%.2f MB", float64(m.Sys)/1024/1024)
+				if er := d.UpdateDatapointValue(mem, uuid.Nil, path); er != nil {
+					d.Log.Error("dmb.Handler.AddSystemDps.UpdateDatapointValue", er.Error())
+				}
+				mOld = m.Sys
+			}
+			time.Sleep(time.Second)
+		}
+	}()
+	return nil
+}

models/uuids.go

@@ -0,0 +1,5 @@
+package models
+
+import "github.com/google/uuid"
+
+type Uuids map[uuid.UUID]*Datapoint

server/models/clients.go

@@ -3,7 +3,6 @@ package models
 import (
 	"context"
 	"fmt"
-	"time"
 
 	"github.com/coder/websocket"
 	"github.com/gin-gonic/gin"
@@ -37,7 +36,7 @@ func (cl *Clients) ConnectRecievingWsConnection(id string, c *gin.Context) error
 	if err != nil {
 		return fmt.Errorf("error accept websocket client: %s", err)
 	}
-	ctx, cancel := context.WithTimeout(context.Background(), 3*time.Minute)
+	ctx, cancel := context.WithCancel(context.Background())
 
 	(*cl)[id] = &Client{
 		Connected: true,

server/models/connections.go

@@ -1,17 +1,24 @@
 package models
 
 import (
+	"context"
+	"encoding/json"
+	"fmt"
 	"sync"
+	"time"
 
 	"github.com/coder/websocket"
 	"github.com/gin-gonic/gin"
+	json_dataModels "github.com/tecamino/tecamino-json_data/models"
 )
 
+// serves as connection handler of websocket
 type Connections struct {
 	sync.RWMutex
 	Clients Clients
 }
 
+// initaiates new conections with client map
 func NewConnections() *Connections {
 	return &Connections{
 		Clients: NewClients(),
@@ -30,3 +37,31 @@ func (c *Connections) RemoveClient(id string) {
 func (c *Connections) DisconnectWsConnection(id string, code websocket.StatusCode, reason string) {
 	c.Clients.DisconnectWsConnection(id, code, reason)
 }
+
+// sends json response to client
+func (c *Connections) SendResponse(id string, r *json_dataModels.Response) error {
+	client, ok := c.Clients[id]
+	if !ok {
+		return fmt.Errorf("client not found for id %s", id)
+
+	}
+	b, err := json.Marshal(r)
+	if err != nil {
+		return err
+	}
+
+	ctx, cancel := context.WithTimeout(context.Background(), 30*time.Second)
+	defer cancel()
+
+	w, err := client.Conn.Writer(ctx, websocket.MessageText)
+	if err != nil {
+		return err
+	}
+	defer w.Close()
+
+	_, err = w.Write(b)
+	if err != nil {
+		return err
+	}
+	return nil
+}

server/server.go

@@ -9,22 +9,30 @@ import (
 	"github.com/tecamino/tecamino-logger/logging"
 )
 
+// server model for database manager websocket
 type Server struct {
 	Routes *gin.Engine
 	sync.RWMutex
 	Logger *logging.Logger
 }
 
+// initalizes new dbm server
 func NewServer() *Server {
 	return &Server{
 		Routes: gin.Default(),
 	}
 }
 
+// serve dbm as http
 func (s *Server) ServeHttp(port uint) error {
 	return s.Routes.Run(fmt.Sprintf(":%d", port))
 }
 
+// serve dbm as http
 func (s *Server) ServeHttps(port uint, cert cert.Cert) error {
+	// generate self signed tls certificate
+	if err := cert.GenerateSelfSignedCert(); err != nil {
+		return err
+	}
 	return s.Routes.RunTLS(fmt.Sprintf(":%d", port), cert.CertFile, cert.KeyFile)
 }

test/dbm_test.go

@@ -7,6 +7,7 @@ import (
 	"testing"
 	"time"
 
+	"github.com/google/uuid"
 	"github.com/tecamino/tecamino-dbm/args"
 	"github.com/tecamino/tecamino-dbm/cert"
 	"github.com/tecamino/tecamino-dbm/dbm"
@@ -87,11 +88,7 @@ func TestQuery(t *testing.T) {
 		panic(err)
 	}
 
-	// for i, o := range dmaHandler.QueryDatapoints(".*002.*") {
+	for i, o := range dmaHandler.DBM.QueryDatapoints(1, uuid.Nil, "Test:A:000") {
-	// 	fmt.Println(600, i, o)
-	// }
-
-	for i, o := range dmaHandler.QueryDatapoints(1, "Test:A:000") {
 		fmt.Println(600, i, o)
 	}
 

utils/convert.go

@@ -5,6 +5,7 @@ import (
 	"strings"
 )
 
+// return any input type to float32
 func Float32From(v any) float32 {
 	switch val := v.(type) {
 	case bool:
@@ -44,6 +45,7 @@ func Float32From(v any) float32 {
 	}
 }
 
+// return any input type to float64
 func Float64From(v any) float64 {
 	switch val := v.(type) {
 	case bool:
@@ -83,6 +85,7 @@ func Float64From(v any) float64 {
 	}
 }
 
+// return any input type to int8
 func Int8From(v any) int8 {
 	switch val := v.(type) {
 	case bool:
@@ -122,6 +125,7 @@ func Int8From(v any) int8 {
 	}
 }
 
+// return any input type to int16
 func Int16From(v any) int16 {
 	switch val := v.(type) {
 	case bool:
@@ -161,6 +165,7 @@ func Int16From(v any) int16 {
 	}
 }
 
+// return any input type to int32
 func Int32From(v any) int32 {
 	switch val := v.(type) {
 	case bool:
@@ -200,6 +205,7 @@ func Int32From(v any) int32 {
 	}
 }
 
+// return any input type to int64
 func Int64From(v any) int64 {
 	switch val := v.(type) {
 	case bool:
@@ -239,6 +245,7 @@ func Int64From(v any) int64 {
 	}
 }
 
+// return any input type to int
 func Uint8From(v any) uint8 {
 	switch val := v.(type) {
 	case bool:
@@ -278,6 +285,7 @@ func Uint8From(v any) uint8 {
 	}
 }
 
+// return any input type to uint16
 func Uint16From(v any) uint16 {
 	switch val := v.(type) {
 	case bool:
@@ -317,6 +325,7 @@ func Uint16From(v any) uint16 {
 	}
 }
 
+// return any input type to uint32
 func Uint32From(v any) uint32 {
 	switch val := v.(type) {
 	case bool:
@@ -356,6 +365,7 @@ func Uint32From(v any) uint32 {
 	}
 }
 
+// return any input type to uint64
 func Uint64From(v any) uint64 {
 	switch val := v.(type) {
 	case bool:
@@ -395,6 +405,7 @@ func Uint64From(v any) uint64 {
 	}
 }
 
+// return any input type to bool
 func BoolFrom(v any) bool {
 	switch val := v.(type) {
 	case bool: