Compare commits
1 Commits
Author | SHA1 | Date | |
---|---|---|---|
dbcd7b20f7 |
@ -1,9 +0,0 @@
|
|||||||
package api
|
|
||||||
|
|
||||||
import "git.cmdq.io/meirjann/DataLogue-Backend/log"
|
|
||||||
|
|
||||||
var logger = log.New("api")
|
|
||||||
|
|
||||||
func Serve() {
|
|
||||||
logger.Println("starting server...")
|
|
||||||
}
|
|
@ -1,9 +0,0 @@
|
|||||||
package configs
|
|
||||||
|
|
||||||
import "git.cmdq.io/meirjann/DataLogue-Backend/log"
|
|
||||||
|
|
||||||
var logger = log.New("init")
|
|
||||||
|
|
||||||
func Init() {
|
|
||||||
logger.Println("initializing...")
|
|
||||||
}
|
|
@ -1,67 +0,0 @@
|
|||||||
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
|
|
||||||
}
|
|
5
go.mod
5
go.mod
@ -1,5 +0,0 @@
|
|||||||
module git.cmdq.io/meirjann/DataLogue-Backend
|
|
||||||
|
|
||||||
go 1.21.4
|
|
||||||
|
|
||||||
require github.com/lib/pq v1.10.9
|
|
2
go.sum
2
go.sum
@ -1,2 +0,0 @@
|
|||||||
github.com/lib/pq v1.10.9 h1:YXG7RB+JIjhP29X+OtkiDnYaXQwpS4JEWq7dtCCRUEw=
|
|
||||||
github.com/lib/pq v1.10.9/go.mod h1:AlVN5x4E4T544tWzH6hKfbfQvm3HdbOxrmggDNAPY9o=
|
|
@ -1,24 +0,0 @@
|
|||||||
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)
|
|
||||||
}
|
|
24
main.go
24
main.go
@ -1,24 +0,0 @@
|
|||||||
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()
|
|
||||||
}
|
|
Loading…
Reference in New Issue
Block a user