17 Commits

Author SHA1 Message Date
Adrian Zürcher
836a69f914 add dbm new model and fixed json_data 2025-05-12 17:12:25 +02:00
Adrian Zürcher
5ee97416dd add comments 2025-05-08 17:28:47 +02:00
Adrian Zürcher
ecb1f3b2cf exclude system datapoints from saving 2025-05-08 17:28:35 +02:00
Adrian Zuercher
5203fb8543 new json_data model 2025-05-04 22:21:12 +02:00
Adrian Zürcher
7d6b09cf11 fix double use of name 2025-05-01 12:52:51 +02:00
Adrian Zürcher
0fe813acd9 convert milliseconds to date and time 2025-05-01 12:52:19 +02:00
Adrian Zürcher
75eb31abf6 add new model datapoint 2025-05-01 12:52:01 +02:00
Adrian Zürcher
4b36598bd7 abstract write to websocket and add request id 2025-05-01 12:51:35 +02:00
Adrian Zürcher
8e6b39c8bf Merge branch 'main' of https://github.com/tecamino/tecamino-dbm 2025-04-30 08:38:29 +02:00
zuadi
2f88525257 add file extention for windows build 2025-04-30 08:38:11 +02:00
Adrian Zürcher
3551cb035b add file extention for windows build 2025-04-30 08:36:54 +02:00
Adrian Zürcher
e5c08f69a9 add error log for https 2025-04-30 08:27:51 +02:00
Adrian Zürcher
f5890c1563 generate certs files only when not existent 2025-04-30 08:27:40 +02:00
zuadi
c310414b7e Update build.yml
fix upload artifacts
2025-04-30 08:13:36 +02:00
zuadi
9e2cd260d5 Update build.yml
add token for actions
2025-04-30 08:10:16 +02:00
zuadi
f37a69e75b Update build.yml 2025-04-30 08:00:59 +02:00
zuadi
c623d89f94 Create build.yml 2025-04-30 07:55:51 +02:00
23 changed files with 879 additions and 1141 deletions

48
.github/workflows/build.yml vendored Normal file
View File

@@ -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/

View File

@@ -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{

View File

@@ -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)
// _, err2 := os.Stat(c.KeyFile)
// if !os.IsNotExist(err) && !os.IsNotExist(err2) {
// return nil
// }
_, err := os.Stat(c.CertFile)
_, err2 := os.Stat(c.KeyFile)
if !os.IsNotExist(err) && !os.IsNotExist(err2) {
return nil
}
priv, err := rsa.GenerateKey(rand.Reader, 2048)
if err != nil {

View File

@@ -13,14 +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 %d datapoints saved in: %v", d.GetNumbersOfDatapoints(), time.Since(s)))
d.Log.Info("db.SaveData", fmt.Sprintf("DBM %d datapoints 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)
}

View File

@@ -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
DB models.Datapoint
DBM *models.DBM
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)
}

39
dbm/get.go Normal file
View File

@@ -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())
}
}

View File

@@ -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.QueryDatapoints(depth, get.Path) {
for _, res := range d.DBM.QueryDatapoints(depth, get.Uuid, 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
}

View File

@@ -4,15 +4,17 @@ import (
json_dataModels "github.com/tecamino/tecamino-json_data/models"
)
func (d *DBMHandler) Set(sets []json_dataModels.Set) {
if sets == nil {
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 sets {
for _, dp := range d.DB.QueryDatapoints(1, set.Path) {
for _, set := range req.Set {
for _, dp := range d.DBM.QueryDatapoints(1, set.Uuid, set.Path) {
dp.UpdateValue(d.Conns, set.Value)
}
}

View File

@@ -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) {
if subs == nil {
func (d *DBMHandler) Subscribe(req *json_dataModels.Request, id string) {
if req == nil {
return
}
if len(req.Subscribe) == 0 {
return
}
d.RLock()
defer d.RUnlock()
client, ok := d.Conns.Clients[id]
if !ok {
d.Log.Error("subscribe.Subscribe", "client not found for id "+id)
return
}
resp := json_dataModels.NewResponse()
resp.Id = req.Id
response := json_dataModels.NewResponse()
for _, sub := range subs {
for _, dp := range d.DB.QueryDatapoints(sub.Depth, sub.Path) {
for _, sub := range req.Subscribe {
for _, dp := range d.DBM.QueryDatapoints(sub.Depth, sub.Uuid, 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) {
if subs == nil {
func (d *DBMHandler) Unsubscribe(req *json_dataModels.Request, id string) {
if req == nil {
return
}
if len(req.Unsubscribe) == 0 {
return
}
d.RLock()
defer d.RUnlock()
client, ok := d.Conns.Clients[id]
if !ok {
d.Log.Error("subscribe.Subscribe", "client not found for id "+id)
return
}
resp := json_dataModels.NewResponse()
resp.Id = req.Id
response := json_dataModels.NewResponse()
for _, sub := range subs {
for _, dp := range d.DB.QueryDatapoints(sub.Depth, sub.Path) {
for _, sub := range req.Unsubscribe {
for _, dp := range d.DBM.QueryDatapoints(sub.Depth, sub.Uuid, 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 {
d.Log.Error("subscribe.Subscribe", err.Error())
if err := d.Conns.SendResponse(id, resp); err != nil {
d.Log.Error("subscribe.Unsubscribe", err.Error())
}
}

View File

@@ -1,11 +1,8 @@
package dbm
import (
"fmt"
"runtime"
"time"
"github.com/tecamino/tecamino-dbm/utils"
"github.com/google/uuid"
"github.com/tecamino/tecamino-dbm/models"
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)
d.UpdateDatapointValue(path, dp[0].GetValueUint64()+1)
models.SystemDatapoints = d.DBM.QueryDatapoints(1, uuid.Nil, path)[0].Uuid
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
}

View File

@@ -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,31 +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
go d.Set(request.Set)
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)
@@ -74,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
}

View File

@@ -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"}

2
go.mod
View File

@@ -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
)

4
go.sum
View File

@@ -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.10/go.mod h1:LLlyD7Wwqplb2BP4PeO86EokEcTRidlW5MwgPd1T2JY=
github.com/tecamino/tecamino-json_data v0.0.13 h1:hugbmCgXXh0F7YQAEbbJYHkSdq1caejD7SajDiMs42I=
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=

11
main.go
View File

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

408
models/datapoint.go Normal file
View File

@@ -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
}

View File

@@ -1,392 +1,12 @@
package models
import (
"errors"
"fmt"
"regexp"
"strings"
"time"
import "sort"
"github.com/coder/websocket/wsjson"
"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"
)
type Datapoints []*Datapoint
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, 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,
func (d *Datapoints) SortSlice() {
// Sort by Path before processing
sort.Slice(*d, func(i, j int) bool {
return (*d)[i].Path < (*d)[j].Path
})
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, 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)
}
}
}
// 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) 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 []*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
}

190
models/dbm.go Normal file
View File

@@ -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
}

5
models/uuids.go Normal file
View File

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

View File

@@ -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
}

View File

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

View File

@@ -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.*") {
// fmt.Println(600, i, o)
// }
for i, o := range dmaHandler.QueryDatapoints(1, "Test:A:000") {
for i, o := range dmaHandler.DBM.QueryDatapoints(1, uuid.Nil, "Test:A:000") {
fmt.Println(600, i, o)
}

View File

@@ -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: