remove method Connect in kontor-echo
This commit is contained in:
@@ -1,4 +1,3 @@
|
|||||||
|
|
||||||
services:
|
services:
|
||||||
postgres:
|
postgres:
|
||||||
image: postgres
|
image: postgres
|
||||||
@@ -36,4 +35,4 @@ secrets:
|
|||||||
networks:
|
networks:
|
||||||
database:
|
database:
|
||||||
name: database
|
name: database
|
||||||
|
external: true
|
||||||
|
|||||||
@@ -4,18 +4,18 @@ import (
|
|||||||
"kontor-api-echo/pkg/handler"
|
"kontor-api-echo/pkg/handler"
|
||||||
"kontor-api-echo/pkg/schema"
|
"kontor-api-echo/pkg/schema"
|
||||||
"log"
|
"log"
|
||||||
|
"os"
|
||||||
|
|
||||||
// jwtware "github.com/gofiber/contrib/jwt"
|
|
||||||
// "github.com/gofiber/fiber/v2/middleware/logger"
|
|
||||||
echojwt "github.com/labstack/echo-jwt/v4"
|
echojwt "github.com/labstack/echo-jwt/v4"
|
||||||
"github.com/labstack/echo/v4"
|
"github.com/labstack/echo/v4"
|
||||||
"github.com/labstack/echo/v4/middleware"
|
"github.com/labstack/echo/v4/middleware"
|
||||||
)
|
)
|
||||||
|
|
||||||
func main() {
|
func main() {
|
||||||
|
log.SetOutput(os.Stdout)
|
||||||
log.Println("Kontor started")
|
log.Println("Kontor started")
|
||||||
|
|
||||||
if err := schema.Connect(); err != nil {
|
if _, err := schema.GetDatabase(); err != nil {
|
||||||
log.Fatal(err)
|
log.Fatal(err)
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -23,28 +23,17 @@ func main() {
|
|||||||
e.GET("/health", handler.GetHealth)
|
e.GET("/health", handler.GetHealth)
|
||||||
e.POST("/login", handler.Login)
|
e.POST("/login", handler.Login)
|
||||||
|
|
||||||
// skipper := func(c echo.Context) bool {
|
skipper := func(c echo.Context) bool {
|
||||||
// // Skip health check endpoint
|
// Skip health check endpoint
|
||||||
// return c.Request().URL.Path == "/health"
|
return c.Request().URL.Path == "/health"
|
||||||
// }
|
}
|
||||||
// e.Use(middleware.RequestLoggerWithConfig(middleware.RequestLoggerConfig{
|
|
||||||
// LogStatus: true,
|
|
||||||
// LogURI: true,
|
|
||||||
// Skipper: skipper,
|
|
||||||
// BeforeNextFunc: func(c echo.Context) {
|
|
||||||
// c.Set("customValueFromContext", 42)
|
|
||||||
// },
|
|
||||||
// LogValuesFunc: func(c echo.Context, v middleware.RequestLoggerValues) error {
|
|
||||||
// value, _ := c.Get("customValueFromContext").(int)
|
|
||||||
// log.Printf("REQUEST: uri: %v, status: %v, custom-value: %v\n", v.URI, v.Status, value)
|
|
||||||
// return nil
|
|
||||||
// },
|
|
||||||
// }))
|
|
||||||
e.Use(middleware.RequestLoggerWithConfig(middleware.RequestLoggerConfig{
|
e.Use(middleware.RequestLoggerWithConfig(middleware.RequestLoggerConfig{
|
||||||
LogStatus: true,
|
LogStatus: true,
|
||||||
LogURI: true,
|
LogURI: true,
|
||||||
LogError: true,
|
LogError: true,
|
||||||
HandleError: true,
|
HandleError: true,
|
||||||
|
Skipper: skipper,
|
||||||
LogValuesFunc: func(c echo.Context, v middleware.RequestLoggerValues) error {
|
LogValuesFunc: func(c echo.Context, v middleware.RequestLoggerValues) error {
|
||||||
if v.Error == nil {
|
if v.Error == nil {
|
||||||
log.Printf("REQUEST: uri: %v, status: %v\n", v.URI, v.Status)
|
log.Printf("REQUEST: uri: %v, status: %v\n", v.URI, v.Status)
|
||||||
@@ -56,20 +45,6 @@ func main() {
|
|||||||
}))
|
}))
|
||||||
|
|
||||||
group := e.Group("/api")
|
group := e.Group("/api")
|
||||||
group.Use(middleware.RequestLoggerWithConfig(middleware.RequestLoggerConfig{
|
|
||||||
LogStatus: true,
|
|
||||||
LogURI: true,
|
|
||||||
LogError: true,
|
|
||||||
HandleError: true,
|
|
||||||
LogValuesFunc: func(c echo.Context, v middleware.RequestLoggerValues) error {
|
|
||||||
if v.Error == nil {
|
|
||||||
log.Printf("REQUEST: uri: %v, status: %v\n", v.URI, v.Status)
|
|
||||||
} else {
|
|
||||||
log.Printf("REQUEST-ERROR: uri: %v, status: %v, err: %v\n", v.URI, v.Status, v.Error.Error())
|
|
||||||
}
|
|
||||||
return nil
|
|
||||||
},
|
|
||||||
}))
|
|
||||||
group.Use(echojwt.WithConfig(echojwt.Config{SigningKey: []byte("secret")}))
|
group.Use(echojwt.WithConfig(echojwt.Config{SigningKey: []byte("secret")}))
|
||||||
handler.SetupComicRoutes(group)
|
handler.SetupComicRoutes(group)
|
||||||
handler.SetupMediaRoutes(group)
|
handler.SetupMediaRoutes(group)
|
||||||
|
|||||||
@@ -11,25 +11,6 @@ import (
|
|||||||
|
|
||||||
var DB *bun.DB
|
var DB *bun.DB
|
||||||
|
|
||||||
func Connect() error {
|
|
||||||
var err error
|
|
||||||
|
|
||||||
dsn := "postgres://kontor:kontor@postgres:5432/kontor?sslmode=disable"
|
|
||||||
sqldb := sql.OpenDB(pgdriver.NewConnector(pgdriver.WithDSN(dsn)))
|
|
||||||
|
|
||||||
sqldb.SetMaxOpenConns(4)
|
|
||||||
sqldb.SetMaxIdleConns(4)
|
|
||||||
|
|
||||||
DB := bun.NewDB(sqldb, pgdialect.New())
|
|
||||||
|
|
||||||
if err = DB.Ping(); err != nil {
|
|
||||||
return err
|
|
||||||
}
|
|
||||||
|
|
||||||
log.Println("Connection Opened to Database")
|
|
||||||
return nil
|
|
||||||
}
|
|
||||||
|
|
||||||
func GetDatabase() (*bun.DB, error) {
|
func GetDatabase() (*bun.DB, error) {
|
||||||
var err error
|
var err error
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user