From c1d822b296ac4f966ae386ae9667808d2f18bec6 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Adrian=20Z=C3=BCrcher?= <zuercher@mst.local>
Date: Tue, 29 Apr 2025 08:32:06 +0200
Subject: [PATCH] change dma to dbm

---
 args/args.go      |  8 +++---
 dbm/dbmHandler.go |  2 +-
 test/dbm_test.go  | 64 +++++++++++++++++++++++------------------------
 3 files changed, 37 insertions(+), 37 deletions(-)

diff --git a/args/args.go b/args/args.go
index 23de884..0703d73 100644
--- a/args/args.go
+++ b/args/args.go
@@ -3,15 +3,15 @@ package args
 import (
 	"flag"
 
-	"github.com/zuadi/tecamino-dbm/cert"
-	"github.com/zuadi/tecamino-dbm/models"
+	"github.com/tecamino/tecamino-dbm/cert"
+	"github.com/tecamino/tecamino-dbm/models"
 )
 
 type Args struct {
 	Port    models.Port
 	Cert    cert.Cert
 	RootDir string
-	DMAFile string
+	DBMFile string
 	Debug   bool
 }
 
@@ -28,7 +28,7 @@ func Init() *Args {
 			Https: *flag.Uint("https-port", 8101, "json server communication for http/wss"),
 		},
 		RootDir: *flag.String("workingDir", "./", "working directory"),
-		DMAFile: *flag.String("dma", "/test/test", "dma file name"),
+		DBMFile: *flag.String("dbm", "/test/test", "dbm file name"),
 		Debug:   *flag.Bool("debug", false, "debug flag"),
 	}
 	flag.Parse()
diff --git a/dbm/dbmHandler.go b/dbm/dbmHandler.go
index 0b0fab5..2a5c2d5 100644
--- a/dbm/dbmHandler.go
+++ b/dbm/dbmHandler.go
@@ -44,7 +44,7 @@ func NewDbmHandler(a *args.Args) (*DBMHandler, error) {
 	// Initialize dtabase manager handler
 	dmaHandler := DBMHandler{
 		arg:      a,
-		filePath: fmt.Sprintf("%s/%s.dma", a.RootDir, a.DMAFile),
+		filePath: fmt.Sprintf("%s/%s.dbm", a.RootDir, a.DBMFile),
 		Log:      logger,
 		Conns:    serverModels.NewConnections(),
 	}
diff --git a/test/dbm_test.go b/test/dbm_test.go
index ff836df..5703ff2 100644
--- a/test/dbm_test.go
+++ b/test/dbm_test.go
@@ -7,12 +7,12 @@ import (
 	"testing"
 	"time"
 
-	"github.com/zuadi/tecamino-dbm/args"
-	"github.com/zuadi/tecamino-dbm/cert"
-	"github.com/zuadi/tecamino-dbm/dbm"
-	"github.com/zuadi/tecamino-dbm/models"
-	"github.com/zuadi/tecamino-dbm/server"
-	"github.com/zuadi/tecamino-dbm/utils"
+	"github.com/tecamino/tecamino-dbm/args"
+	"github.com/tecamino/tecamino-dbm/cert"
+	"github.com/tecamino/tecamino-dbm/dbm"
+	"github.com/tecamino/tecamino-dbm/models"
+	"github.com/tecamino/tecamino-dbm/server"
+	"github.com/tecamino/tecamino-dbm/utils"
 )
 
 func TestCreateDps(t *testing.T) {
@@ -27,7 +27,7 @@ func TestCreateDps(t *testing.T) {
 			KeyFile:      "./cert/key.pem",
 		},
 		RootDir: ".",
-		DMAFile: "Test",
+		DBMFile: "Test",
 		Debug:   false,
 	})
 	if err != nil {
@@ -39,18 +39,18 @@ func TestCreateDps(t *testing.T) {
 	ndps := utils.ListofA2ZZ()
 	l := len(ndps)
 	s := time.Now()
-	for _, dp := range ndps {
-		for i := 0; i < 100; i++ {
-			err = dmaHandler.ImportDatapoints(&models.Datapoint{
-				Path:  fmt.Sprintf("Test:%s:%03d", dp, i),
-				Type:  RandomType(),
-				Value: rand.Int31(),
-			})
-			if err != nil {
-				t.Fatal(err)
-			}
-		}
-	}
+	// for _, dp := range ndps {
+	// 	for i := 0; i < 100; i++ {
+	// 		err = dmaHandler.ImportDatapoints(&models.Datapoint{
+	// 			Path:  fmt.Sprintf("Test:%s:%03d", dp, i),
+	// 			Type:  models.RandomType(),
+	// 			Value: rand.Int31(),
+	// 		})
+	// 		if err != nil {
+	// 			t.Fatal(err)
+	// 		}
+	// 	}
+	// }
 	fmt.Printf("time used to create %d datapoints: %v\n", l*100, time.Since(s))
 
 	var m runtime.MemStats
@@ -80,7 +80,7 @@ func TestQuery(t *testing.T) {
 			KeyFile:      "./cert/key.pem",
 		},
 		RootDir: ".",
-		DMAFile: "Test",
+		DBMFile: "Test",
 		Debug:   false,
 	})
 	if err != nil {
@@ -109,7 +109,7 @@ func TestUpdateDps(t *testing.T) {
 			KeyFile:      "./cert/key.pem",
 		},
 		RootDir: ".",
-		DMAFile: "Test",
+		DBMFile: "Test",
 		Debug:   false,
 	})
 	if err != nil {
@@ -121,17 +121,17 @@ func TestUpdateDps(t *testing.T) {
 	ndps := utils.ListofA2ZZ()
 	l := len(ndps)
 	s := time.Now()
-	for j, dp := range ndps {
-		if j > 2 {
-			break
-		}
-		for i := 0; i < 100; i++ {
-			err = dmaHandler.UpdateDatapointValue(fmt.Sprintf("Test:%s:%03d", dp, i), rand.Int31())
-			if err != nil {
-				t.Fatal(err)
-			}
-		}
-	}
+	// for j, dp := range ndps {
+	// 	if j > 2 {
+	// 		break
+	// 	}
+	// 	for i := 0; i < 100; i++ {
+	// 		err = dmaHandler.UpdateDatapointValue(fmt.Sprintf("Test:%s:%03d", dp, i), rand.Int31())
+	// 		if err != nil {
+	// 			t.Fatal(err)
+	// 		}
+	// 	}
+	// }
 	fmt.Printf("time used to update %d datapoints: %v\n", l*100, time.Since(s))
 
 	time.Sleep(5 * time.Second)