From c713c013f80159c992dea2c1624e5f6325743b30 Mon Sep 17 00:00:00 2001
From: moxitech <moxitechofficial@gmail.com>
Date: Mon, 27 May 2024 14:42:26 +0700
Subject: [PATCH] update

---
 .gitignore  |   1 +
 app/main.go | 180 ++++++++++++++++++++++++++--------------------------
 2 files changed, 90 insertions(+), 91 deletions(-)
 create mode 100644 .gitignore

diff --git a/.gitignore b/.gitignore
new file mode 100644
index 0000000..485dee6
--- /dev/null
+++ b/.gitignore
@@ -0,0 +1 @@
+.idea
diff --git a/app/main.go b/app/main.go
index 124cbab..d172218 100644
--- a/app/main.go
+++ b/app/main.go
@@ -1,100 +1,98 @@
 package main
 
+
+
+
 func main() {
+	//LOAD FROM DOTENV VARS
+	//err := godotenv.Load()
+	//if err != nil {
+	//	fmt.Printf("Ошибка чтения .env файла %s", err)
+	//}
+	// === Logger  Example [Using Sentry!] ===
+	//logger := logger2.NewLoggerAndExceptionHandler()
+	//logger.Info("Hello World")
+	//logger.Fatal("Fatal Msg")
+
+	// === Device status example [Using Redis!] ===
+	//ctx := context.Background()
+	//redisClient := redis.NewClient(&redis.Options{
+	//	Addr: "localhost:6379",
+	//})
+	//ds := device_status.NewDeviceStatus(redisClient)
+	//err := ds.SetOnline(ctx, "device_1")
+	//if err != nil {
+	//	fmt.Printf("Error while set online: %s", err)
+	//}
+	//status, err := ds.GetOnline(ctx, "device_1")
+	//if err != nil {
+	//	fmt.Printf("Error while set offline: %s", err)
+	//}
+	//fmt.Printf("Device status: %s", status)
+	//err = ds.SetOffline(ctx, "device_1")
+	//if err != nil {
+	//	panic(err)
+	//}
+
+	/* DB TEST */
+	//database := databases.NewDatabase()
+	//// Example query
+	//rows, err := database.Query("SELECT * FROM users")
+	//if err != nil {
+	//	log.Fatal(err)
+	//}
+	//// Process rows
+	//for rows.Next() {
+	//	var id int
+	//	var name string
+	//	if err := rows.Scan(&id, &name); err != nil {
+	//		log.Fatal(err)
+	//	}
+	//	fmt.Println(id, name)
+	//}
+	//database.Close()
+
+	// /* Clickhouse */
+	//ch := databases.NewClickhouse()
+	//err := ch.InitDB()
+	//if err != nil {
+	//	log.Fatal(err)
+	//}
+	//
+	//go func() {
+	//	for {
+	//		time.Sleep(time.Second)
+	//
+	//		for table, data := range ch.TablesQueues {
+	//			if len(data) >= ch.NeedCountForTable[table] {
+	//				err := ch.FlushQueue(table)
+	//				if err != nil {
+	//					log.Println("Error flushing queue:", err)
+	//				}
+	//			}
+	//		}
+	//	}
+	//}()
+	//
+	//// Example usage:
+	//data := []interface{}{"1", "2", "3"}
+	//err = ch.Insert("device_traffic", data)
+	//if err != nil {
+	//	log.Println("Error inserting data:", err)
+	//}
+
+	/* Request controller */
+	//rc := lib.NewRequestController()
+	//devID := "1#1"
+	//data := map[string]interface{}{
+	//	"k": "v",
+	//}
+	//ts := time.Now()
+	//
+	//rc.WriteLog(devID, data, ts)
 
 }
 
-//
-//func main() {
-//	//LOAD FROM DOTENV VARS
-//	//err := godotenv.Load()
-//	//if err != nil {
-//	//	fmt.Printf("Ошибка чтения .env файла %s", err)
-//	//}
-//	// === Logger  Example [Using Sentry!] ===
-//	//logger := logger2.NewLoggerAndExceptionHandler()
-//	//logger.Info("Hello World")
-//	//logger.Fatal("Fatal Msg")
-//
-//	// === Device status example [Using Redis!] ===
-//	//ctx := context.Background()
-//	//redisClient := redis.NewClient(&redis.Options{
-//	//	Addr: "localhost:6379",
-//	//})
-//	//ds := device_status.NewDeviceStatus(redisClient)
-//	//err := ds.SetOnline(ctx, "device_1")
-//	//if err != nil {
-//	//	fmt.Printf("Error while set online: %s", err)
-//	//}
-//	//status, err := ds.GetOnline(ctx, "device_1")
-//	//if err != nil {
-//	//	fmt.Printf("Error while set offline: %s", err)
-//	//}
-//	//fmt.Printf("Device status: %s", status)
-//	//err = ds.SetOffline(ctx, "device_1")
-//	//if err != nil {
-//	//	panic(err)
-//	//}
-//
-//	/* DB TEST */
-//	//database := databases.NewDatabase()
-//	//// Example query
-//	//rows, err := database.Query("SELECT * FROM users")
-//	//if err != nil {
-//	//	log.Fatal(err)
-//	//}
-//	//// Process rows
-//	//for rows.Next() {
-//	//	var id int
-//	//	var name string
-//	//	if err := rows.Scan(&id, &name); err != nil {
-//	//		log.Fatal(err)
-//	//	}
-//	//	fmt.Println(id, name)
-//	//}
-//	//database.Close()
-//
-//	// /* Clickhouse */
-//	//ch := databases.NewClickhouse()
-//	//err := ch.InitDB()
-//	//if err != nil {
-//	//	log.Fatal(err)
-//	//}
-//	//
-//	//go func() {
-//	//	for {
-//	//		time.Sleep(time.Second)
-//	//
-//	//		for table, data := range ch.TablesQueues {
-//	//			if len(data) >= ch.NeedCountForTable[table] {
-//	//				err := ch.FlushQueue(table)
-//	//				if err != nil {
-//	//					log.Println("Error flushing queue:", err)
-//	//				}
-//	//			}
-//	//		}
-//	//	}
-//	//}()
-//	//
-//	//// Example usage:
-//	//data := []interface{}{"1", "2", "3"}
-//	//err = ch.Insert("device_traffic", data)
-//	//if err != nil {
-//	//	log.Println("Error inserting data:", err)
-//	//}
-//
-//	/* Request controller */
-//	//rc := lib.NewRequestController()
-//	//devID := "1#1"
-//	//data := map[string]interface{}{
-//	//	"k": "v",
-//	//}
-//	//ts := time.Now()
-//	//
-//	//rc.WriteLog(devID, data, ts)
-//
-//}
-
 //////////////////////////////////////////////////////////////////////////////////////
 //var libraries = map[string]interface{}{
 //	"version":           "./lib/data_libs.go/version",