From 96307d2979288629c59ba0a309099be358c9e074 Mon Sep 17 00:00:00 2001
From: mkelvers <mikkelelvers@outlook.com>
Date: Tue, 26 May 2026 15:56:38 +0200
Subject: [PATCH] refactor: migrate database logs to observability

---
 internal/database/database.go |  4 ++--
 internal/database/fixes.go    | 11 +++++++++--
 2 files changed, 11 insertions(+), 4 deletions(-)

diff --git a/internal/database/database.go b/internal/database/database.go
index dd3de87..c6e180e 100644
--- a/internal/database/database.go
+++ b/internal/database/database.go
@@ -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)
 	}
diff --git a/internal/database/fixes.go b/internal/database/fixes.go
index 4f73590..dd0a959 100644
--- a/internal/database/fixes.go
+++ b/internal/database/fixes.go
@@ -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)
 		}