From 2bcd9fe9769e49b2fe2664a41008ba9e712e3496 Mon Sep 17 00:00:00 2001
From: Sven Urbanski <sven.urbanski@freiheit.com>
Date: Wed, 2 Oct 2024 17:42:55 +0200
Subject: [PATCH] fix(db): logging

Extend logging to tell us exactly which migration triggered a git pull

Ref: SRX-RH7CD5
---
 pkg/db/db.go                          | 4 ++++
 services/cd-service/pkg/cmd/server.go | 2 ++
 2 files changed, 6 insertions(+)

diff --git a/pkg/db/db.go b/pkg/db/db.go
index de3679079..e594aa02e 100644
--- a/pkg/db/db.go
+++ b/pkg/db/db.go
@@ -2586,7 +2586,11 @@ func (h *DBHandler) NeedsMigrations(ctx context.Context) (bool, error) {
 			if err != nil {
 				return err
 			}
+			if !needs {
+				logger.FromContext(ctx).Sugar().Warnf("migration skipped: %v", i)
+			}
 			if needs {
+				logger.FromContext(ctx).Sugar().Warnf("migration required: %v", i)
 				needsMigration = true
 				return nil
 			}
diff --git a/services/cd-service/pkg/cmd/server.go b/services/cd-service/pkg/cmd/server.go
index f715367b1..41da97c83 100755
--- a/services/cd-service/pkg/cmd/server.go
+++ b/services/cd-service/pkg/cmd/server.go
@@ -345,7 +345,9 @@ func RunServer() {
 			}
 		if dbHandler.ShouldUseOtherTables() {
 			//Check for migrations -> for pulling
+			logger.FromContext(ctx).Sugar().Warnf("checking if migrations are required...")
 			if needsMigration, err := dbHandler.NeedsMigrations(ctx); err == nil && needsMigration {
+				logger.FromContext(ctx).Sugar().Warnf("starting to pull the repo")
 				err := repo.Pull(ctx)
 				if err != nil {
 					logger.FromContext(ctx).Fatal("Could not pull repository to perform custom migrations", zap.Error(err))