Add db to odidere cmd
This commit is contained in:
+38
-10
@@ -11,6 +11,7 @@ import (
|
|||||||
"runtime/debug"
|
"runtime/debug"
|
||||||
|
|
||||||
"code.chimeric.al/chimerical/odidere/internal/config"
|
"code.chimeric.al/chimerical/odidere/internal/config"
|
||||||
|
"code.chimeric.al/chimerical/odidere/internal/db"
|
||||||
"code.chimeric.al/chimerical/odidere/internal/service"
|
"code.chimeric.al/chimerical/odidere/internal/service"
|
||||||
)
|
)
|
||||||
|
|
||||||
@@ -20,13 +21,16 @@ func main() {
|
|||||||
)
|
)
|
||||||
flag.Parse()
|
flag.Parse()
|
||||||
|
|
||||||
var log = slog.New(slog.NewTextHandler(
|
var (
|
||||||
os.Stderr,
|
ctx = context.Background()
|
||||||
&slog.HandlerOptions{
|
log = slog.New(slog.NewTextHandler(
|
||||||
AddSource: true,
|
os.Stderr,
|
||||||
Level: slog.LevelDebug,
|
&slog.HandlerOptions{
|
||||||
},
|
AddSource: true,
|
||||||
))
|
Level: slog.LevelDebug,
|
||||||
|
},
|
||||||
|
))
|
||||||
|
)
|
||||||
if *cfgPath == "" {
|
if *cfgPath == "" {
|
||||||
log.Error("missing config path")
|
log.Error("missing config path")
|
||||||
os.Exit(1)
|
os.Exit(1)
|
||||||
@@ -45,7 +49,7 @@ func main() {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
log.Debug(
|
log.Debug(
|
||||||
"odidered",
|
"odidere",
|
||||||
slog.Group(
|
slog.Group(
|
||||||
"build",
|
"build",
|
||||||
slog.String("commit", commit),
|
slog.String("commit", commit),
|
||||||
@@ -63,7 +67,23 @@ func main() {
|
|||||||
os.Exit(1)
|
os.Exit(1)
|
||||||
}
|
}
|
||||||
|
|
||||||
svc, err := service.New(cfg, log)
|
sdb, err := db.Connect(ctx, db.Config{Path: cfg.Database.Path})
|
||||||
|
if err != nil {
|
||||||
|
log.Error(
|
||||||
|
"failed to connect to database",
|
||||||
|
slog.Any("error", err),
|
||||||
|
)
|
||||||
|
os.Exit(1)
|
||||||
|
}
|
||||||
|
if err := sdb.ApplySchema(ctx, log); err != nil {
|
||||||
|
log.Error(
|
||||||
|
"failed to apply database schema",
|
||||||
|
slog.Any("error", err),
|
||||||
|
)
|
||||||
|
os.Exit(1)
|
||||||
|
}
|
||||||
|
|
||||||
|
svc, err := service.New(cfg, log, sdb)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
log.Error(
|
log.Error(
|
||||||
"failed to create service",
|
"failed to create service",
|
||||||
@@ -72,11 +92,19 @@ func main() {
|
|||||||
os.Exit(1)
|
os.Exit(1)
|
||||||
}
|
}
|
||||||
|
|
||||||
if err := svc.Run(context.Background()); err != nil {
|
if err := svc.Run(ctx); err != nil {
|
||||||
log.Error(
|
log.Error(
|
||||||
"failed to run",
|
"failed to run",
|
||||||
slog.Any("error", err),
|
slog.Any("error", err),
|
||||||
)
|
)
|
||||||
os.Exit(1)
|
os.Exit(1)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
if err := sdb.Close(); err != nil {
|
||||||
|
log.Error(
|
||||||
|
"failed to close database",
|
||||||
|
slog.Any("error", err),
|
||||||
|
)
|
||||||
|
os.Exit(1)
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user