paadi/tecamino-dbm
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Compare commits

base: paadi:v0.0.5
Branches Tags
paadi:main
paadi:v0.1.1 paadi:v0.1.0 paadi:v0.0.22 paadi:v0.0.21 paadi:v0.0.20 paadi:v0.0.19 paadi:v0.0.18 paadi:v0.0.17 paadi:v0.0.16 paadi:v0.0.15 paadi:v0.0.14 paadi:v0.0.13 paadi:v0.0.12 paadi:v0.0.11 paadi:v0.0.10 paadi:v0.0.9 paadi:v0.0.8 paadi:v0.0.7 paadi:v0.0.6 paadi:v0.0.5 paadi:v0.0.4 paadi:v0.0.2 paadi:v0.0.3 paadi:v0.0.1
...
compare: paadi:v0.0.7
Branches Tags
paadi:main
paadi:v0.1.1 paadi:v0.1.0 paadi:v0.0.22 paadi:v0.0.21 paadi:v0.0.20 paadi:v0.0.19 paadi:v0.0.18 paadi:v0.0.17 paadi:v0.0.16 paadi:v0.0.15 paadi:v0.0.14 paadi:v0.0.13 paadi:v0.0.12 paadi:v0.0.11 paadi:v0.0.10 paadi:v0.0.9 paadi:v0.0.8 paadi:v0.0.7 paadi:v0.0.6 paadi:v0.0.5 paadi:v0.0.4 paadi:v0.0.2 paadi:v0.0.3 paadi:v0.0.1

13 Commits
v0.0.5 ... v0.0.7

Author SHA1 Message Date
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
13 changed files with 570 additions and 968 deletions
Expand all files Collapse all files

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/

10
cert/cert.go
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 {

4
dbm/dbmHandler.go
View File

@@ -131,8 +131,8 @@ func (d *DBMHandler) ImportDatapoints(dps ...models.Datapoint) error {
if err != nil {
return err
}
dp := d.QueryDatapoints(1, "System:Datapoints")
d.UpdateDatapointValue("System:Datapoints", dp[0].GetValueUint64()+1)
dps := d.QueryDatapoints(1, "System:Datapoints")
d.UpdateDatapointValue("System:Datapoints", dps[0].GetValueUint64()+1)
}
return nil
}

37
dbm/get.go Normal file
View File

@@ -0,0 +1,37 @@
package dbm
import (
json_data "github.com/tecamino/tecamino-json_data"
json_dataModels "github.com/tecamino/tecamino-json_data/models"
)
func (d *DBMHandler) Get(gets []json_dataModels.Get, id, id2 string) {
if gets == nil {
return
}
d.RLock()
defer d.RUnlock()
r := json_data.NewResponse()
r.Id = id2
for _, get := range gets {
var depth uint = 1
if get.Query != nil {
depth = get.Query.Depth
}
for _, dp := range d.DB.QueryDatapoints(depth, get.Path) {
r.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, r); err != nil {
d.Log.Error("get.Get", err.Error())
}
}

32
dbm/subscribe.go
View File

@@ -1,24 +1,18 @@
package dbm
import (
"github.com/coder/websocket/wsjson"
json_dataModels "github.com/tecamino/tecamino-json_data/models"
)
func (d *DBMHandler) Subscribe(subs []json_dataModels.Subscribe, id string) {
func (d *DBMHandler) Subscribe(subs []json_dataModels.Subscribe, id, id2 string) {
if subs == nil {
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
}
response := json_dataModels.NewResponse()
r := json_dataModels.NewResponse()
r.Id = id2
for _, sub := range subs {
for _, dp := range d.DB.QueryDatapoints(sub.Depth, sub.Path) {
@@ -28,7 +22,7 @@ func (d *DBMHandler) Subscribe(subs []json_dataModels.Subscribe, id string) {
}
}
dp.AddSubscribtion(id, sub)
response.AddSubscription(json_dataModels.Subscribe{
r.AddSubscription(json_dataModels.Subscribe{
Uuid: dp.Uuid,
Path: dp.Path,
Value: dp.Value,
@@ -37,7 +31,8 @@ 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, r); err != nil {
d.Log.Error("subscribe.Subscribe", err.Error())
}
}
@@ -49,13 +44,7 @@ func (d *DBMHandler) Unsubscribe(subs []json_dataModels.Subscribe, id string) {
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
}
response := json_dataModels.NewResponse()
r := json_dataModels.NewResponse()
for _, sub := range subs {
for _, dp := range d.DB.QueryDatapoints(sub.Depth, sub.Path) {
@@ -63,13 +52,14 @@ func (d *DBMHandler) Unsubscribe(subs []json_dataModels.Subscribe, id string) {
continue
}
dp.RemoveSubscribtion(id)
response.AddUnsubscription(json_dataModels.Subscribe{
r.AddUnsubscription(json_dataModels.Subscribe{
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, r); err != nil {
d.Log.Error("subscribe.Unsubscribe", err.Error())
}
}

2
dbm/system.go
View File

@@ -54,7 +54,7 @@ func (d *DBMHandler) GoSystemTime() error {
for {
t := time.Now().UnixMilli()
if tOld != t {
if er := d.DB.UpdateDatapointValue(d.Conns, t, path); er != nil {
if er := d.DB.UpdateDatapointValue(d.Conns, time.UnixMilli(t).Format("2006-01-02 15:04:05"), path); er != nil {
d.Log.Error("dmb.Handler.AddSystemDps.UpdateDatapointValue", er.Error())
}
tOld = t

33
dbm/webSocket.go
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,46 @@ 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.Get, id, request.Id)
// Sets
d.Set(request.Set)
// Subscribe
go d.Subscribe(request.Subscribe, id)
d.Subscribe(request.Subscribe, id, request.Id)
// Unsubscribe
go d.Unsubscribe(request.Unsubscribe, id)
d.Unsubscribe(request.Unsubscribe, id)
request.Get = make([]json_dataModels.Get, 0)
request.Set = make([]json_dataModels.Set, 0)
request.Subscribe = make([]json_dataModels.Subscribe, 0)
request.Unsubscribe = make([]json_dataModels.Subscribe, 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 {
return request, err
}
b, err := io.ReadAll(reader)
if err != nil {
code := websocket.CloseStatus(err)
@@ -74,5 +90,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
}

545
dbmServer.log
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"}

5
main.go
View File

@@ -44,6 +44,9 @@ func main() {
}()
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)
}
}

393
models/datapoint.go Normal file
View File

@@ -0,0 +1,393 @@
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, err error) {
if len(sets) == 0 {
return
}
for _, dp := range sets {
parts := strings.Split(dp.Path, ":")
current := d
for i, part := range parts {
if current.Datapoints == nil {
current.Datapoints = make(map[string]*Datapoint)
}
if i == len(parts)-1 {
// Leaf node: create or update datapoint
if existing, ok := current.Datapoints[part]; ok {
publish, err := existing.Set("", dp)
if err != nil {
return nil, err
}
created = append(created, json_dataModels.Set{
Uuid: existing.Uuid,
Path: existing.Path,
Type: existing.Type,
Value: existing.Value,
Rights: existing.ReadWrite,
Drivers: &existing.Drivers,
Updated: true,
})
if publish {
existing.Publish(conns, OnChange)
}
} else {
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 = 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
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 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.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 _, 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
}

392
models/datapoints.go
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
}

32
server/models/connections.go
View File

@@ -1,10 +1,15 @@
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"
)
type Connections struct {
@@ -30,3 +35,30 @@ func (c *Connections) RemoveClient(id string) {
func (c *Connections) DisconnectWsConnection(id string, code websocket.StatusCode, reason string) {
c.Clients.DisconnectWsConnection(id, code, reason)
}
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 " + 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
}

3
server/server.go
View File

@@ -26,5 +26,8 @@ func (s *Server) ServeHttp(port uint) error {
}
func (s *Server) ServeHttps(port uint, cert cert.Cert) error {
if err := cert.GenerateSelfSignedCert(); err != nil {
return err
}
return s.Routes.RunTLS(fmt.Sprintf(":%d", port), cert.CertFile, cert.KeyFile)
}