postgres init started

README.md

@@ -0,0 +1 @@
+# Backend for DataLogue

api/server.go

@@ -0,0 +1,9 @@
+package api
+
+import "git.cmdq.io/meirjann/DataLogue-Backend/log"
+
+var logger = log.New("api")
+
+func Serve() {
+	logger.Println("starting server...")
+}

configs/init.go

@@ -0,0 +1,9 @@
+package configs
+
+import "git.cmdq.io/meirjann/DataLogue-Backend/log"
+
+var logger = log.New("init")
+
+func Init() {
+	logger.Println("initializing...")
+}

db/pq/init.go

@@ -0,0 +1,67 @@
+package pq
+
+import (
+	"database/sql"
+	"errors"
+	"fmt"
+
+	"git.cmdq.io/meirjann/DataLogue-Backend/log"
+	_ "github.com/lib/pq"
+)
+
+type pqClient struct {
+	c *sql.DB
+}
+
+var (
+	logger = log.New("db")
+	db     = &pqClient{}
+)
+
+const (
+	DB_HOST = "localhost"
+	DB_NAME = "dataloguewdawd"
+	DB_PASS = "datalogueawdawd"
+	DB_USER = "datalogueawdawd"
+)
+
+func Init() error {
+	c, err := initConn()
+	if err != nil {
+		return err
+	}
+	db.c = c
+
+	err = checkOrCreateTables()
+	if err != nil {
+		return err
+	}
+
+	return nil
+}
+
+func initConn() (*sql.DB, error) {
+	connStr := fmt.Sprintf("postgres://%s:%s@%s/%s?sslmode=verify-full", DB_USER, DB_PASS, DB_HOST, DB_NAME)
+	db, err := sql.Open("postgres", connStr)
+	if err != nil {
+		return nil, err
+	}
+	logger.Println("connection to postgres db established")
+	return db, nil
+}
+
+func CloseConn() error {
+	if db.c != nil {
+		err := db.c.Close()
+		if err != nil {
+			return err
+		}
+		logger.Println("connection to postgres db closed")
+		return nil
+	}
+	return errors.New("postgres connection nil, could not close")
+}
+
+func checkOrCreateTables() error {
+	return nil
+}

go.mod

@@ -0,0 +1,5 @@
+module git.cmdq.io/meirjann/DataLogue-Backend
+
+go 1.21.4
+
+require github.com/lib/pq v1.10.9

go.sum

@@ -0,0 +1,2 @@
+github.com/lib/pq v1.10.9 h1:YXG7RB+JIjhP29X+OtkiDnYaXQwpS4JEWq7dtCCRUEw=
+github.com/lib/pq v1.10.9/go.mod h1:AlVN5x4E4T544tWzH6hKfbfQvm3HdbOxrmggDNAPY9o=

log/logger.go

@@ -0,0 +1,24 @@
+package log
+
+import (
+	"io"
+	"log"
+	"os"
+	"time"
+)
+
+type writer struct {
+	io.Writer
+	timeFormat string
+}
+
+func (w writer) Write(b []byte) (n int, err error) {
+	return w.Writer.Write(append([]byte(time.Now().Format(w.timeFormat)), b...))
+}
+
+func New(msg string) *log.Logger {
+	if len(msg) > 0 {
+		return log.New(&writer{os.Stdout, "2006/01/02 15:04:05 "}, "["+msg+"] \t", 0)
+	}
+	return log.New(&writer{os.Stdout, "2006/01/02 15:04:05 "}, "[info] \t", 0)
+}

main.go

@@ -0,0 +1,24 @@
+package main
+
+import (
+	"git.cmdq.io/meirjann/DataLogue-Backend/api"
+	"git.cmdq.io/meirjann/DataLogue-Backend/configs"
+	"git.cmdq.io/meirjann/DataLogue-Backend/db/pq"
+	"git.cmdq.io/meirjann/DataLogue-Backend/log"
+)
+
+var logger = log.New("startup")
+
+func main() {
+	logger.Println("starting...")
+	// set all configs
+	configs.Init()
+	// init db
+	err := pq.Init()
+	if err != nil {
+		panic(err)
+	}
+	defer pq.CloseConn()
+	// start api
+	api.Serve()
+}

test.go

@@ -1,55 +0,0 @@
-package main
-
-import (
-	"fmt"
-	"log"
-	"os"
-	"sync"
-	"time"
-)
-
-func sendA(ch chan string) {
-	fmt.Println("start waiting A")
-	time.Sleep(20 * time.Second)
-	fmt.Println("end waiting A")
-	ch <- "a"
-	close(ch)
-}
-
-func sendB(ch chan string) {
-	fmt.Println("start waiting B")
-	time.Sleep(10 * time.Second)
-	fmt.Println("end waiting B")
-	ch <- "b"
-	close(ch)
-}
-
-func main() {
-	if err := os.Chdir(""); err != nil {
-		fmt.Println("didn't change directory")
-	}
-	wg := sync.WaitGroup{}
-	wg.Add(2)
-	chA := make(chan string)
-	chB := make(chan string)
-	fmt.Println("start sendA")
-	go sendA(chA)
-	fmt.Println("start sendB")
-	go sendB(chB)
-	fmt.Println("start printing A")
-	go printCock(chA, &wg)
-	fmt.Println("start printing B")
-	go printCock(chB, &wg)
-	wg.Wait()
-}
-
-func printCock(ch chan string, wg *sync.WaitGroup) {
-	for {
-		select {
-		case x := <-ch:
-			log.Println(x)
-			wg.Done()
-			return
-		}
-	}
-}