refactor: migrate database logs to observability
This commit is contained in:
@@ -4,9 +4,9 @@ import (
|
||||
"database/sql"
|
||||
"embed"
|
||||
"fmt"
|
||||
"log"
|
||||
"mal/internal/config"
|
||||
"mal/internal/db"
|
||||
"mal/internal/observability"
|
||||
|
||||
"github.com/pressly/goose/v3"
|
||||
"go.uber.org/fx"
|
||||
@@ -42,7 +42,7 @@ func RunMigrations(sqlDB *sql.DB) error {
|
||||
return fmt.Errorf("failed to set goose dialect: %w", err)
|
||||
}
|
||||
|
||||
log.Println("Running database migrations...")
|
||||
observability.Info("db_migrations_start", "database", "", nil)
|
||||
if err := goose.Up(sqlDB, "migrations"); err != nil {
|
||||
return fmt.Errorf("failed to run migrations: %w", err)
|
||||
}
|
||||
|
||||
@@ -4,10 +4,10 @@ import (
|
||||
"context"
|
||||
"database/sql"
|
||||
"fmt"
|
||||
"log"
|
||||
"time"
|
||||
|
||||
dbfixes "mal/internal/database/fixes"
|
||||
"mal/internal/observability"
|
||||
)
|
||||
|
||||
func RunDataFixes(sqlDB *sql.DB) error {
|
||||
@@ -34,7 +34,14 @@ func RunDataFixes(sqlDB *sql.DB) error {
|
||||
continue
|
||||
}
|
||||
|
||||
log.Printf("Running data fix id=%s", fix.ID)
|
||||
observability.Info(
|
||||
"db_data_fix_start",
|
||||
"database",
|
||||
"",
|
||||
map[string]any{
|
||||
"id": fix.ID,
|
||||
},
|
||||
)
|
||||
if err := fix.Apply(ctx, sqlDB); err != nil {
|
||||
return fmt.Errorf("data fix %s failed: %w", fix.ID, err)
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user