fix: resolve cyclop, funlen issues by extracting helper methods

internal/db/db.go

@@ -662,63 +662,52 @@ func (s *Database) applyMigrations(
 	migrations []migration,
 ) error {
 	for _, m := range migrations {
-		var exists int
-
-		err := s.db.QueryRowContext(ctx,
-			"SELECT COUNT(*) FROM schema_migrations WHERE version = ?",
-			m.version,
-		).Scan(&exists)
-		if err != nil {
-			return fmt.Errorf(
-				"check migration %d: %w", m.version, err,
-			)
-		}
-
-		if exists > 0 {
-			continue
-		}
-
-		s.log.Info(
-			"applying migration",
-			"version", m.version, "name", m.name,
-		)
-
-		tx, err := s.db.BeginTx(ctx, nil)
-		if err != nil {
-			return fmt.Errorf(
-				"begin tx for migration %d: %w", m.version, err,
-			)
-		}
-
-		_, err = tx.ExecContext(ctx, m.sql)
-		if err != nil {
-			_ = tx.Rollback()
-
-			return fmt.Errorf(
-				"apply migration %d (%s): %w",
-				m.version, m.name, err,
-			)
-		}
-
-		_, err = tx.ExecContext(ctx,
-			"INSERT INTO schema_migrations (version) VALUES (?)",
-			m.version,
-		)
-		if err != nil {
-			_ = tx.Rollback()
-
-			return fmt.Errorf(
-				"record migration %d: %w", m.version, err,
-			)
-		}
-
-		err = tx.Commit()
-		if err != nil {
-			return fmt.Errorf(
-				"commit migration %d: %w", m.version, err,
-			)
+		if err := s.applyOneMigration(ctx, m); err != nil {
+			return err
 		}
 	}
 
 	return nil
 }
+
+func (s *Database) applyOneMigration(ctx context.Context, m migration) error {
+	var exists int
+
+	err := s.db.QueryRowContext(ctx,
+		"SELECT COUNT(*) FROM schema_migrations WHERE version = ?",
+		m.version,
+	).Scan(&exists)
+	if err != nil {
+		return fmt.Errorf("check migration %d: %w", m.version, err)
+	}
+
+	if exists > 0 {
+		return nil
+	}
+
+	s.log.Info("applying migration", "version", m.version, "name", m.name)
+
+	tx, err := s.db.BeginTx(ctx, nil)
+	if err != nil {
+		return fmt.Errorf("begin tx for migration %d: %w", m.version, err)
+	}
+
+	_, err = tx.ExecContext(ctx, m.sql)
+	if err != nil {
+		_ = tx.Rollback()
+
+		return fmt.Errorf("apply migration %d (%s): %w", m.version, m.name, err)
+	}
+
+	_, err = tx.ExecContext(ctx,
+		"INSERT INTO schema_migrations (version) VALUES (?)",
+		m.version,
+	)
+	if err != nil {
+		_ = tx.Rollback()
+
+		return fmt.Errorf("record migration %d: %w", m.version, err)
+	}
+
+	return tx.Commit()
+}