From a5e79ff9831ce1b6865b2999873fc5b8106a5e43 Mon Sep 17 00:00:00 2001
From: Michael Mraka <michael.mraka@redhat.com>
Date: Tue, 12 Dec 2023 11:19:05 +0100
Subject: [PATCH] RHINENG-6031: remove migration task

---
 manager/routes/routes.go      |  1 -
 turnpike/controllers/admin.go | 60 -----------------------------------
 2 files changed, 61 deletions(-)

diff --git a/manager/routes/routes.go b/manager/routes/routes.go
index fc186f82d..47c07200b 100644
--- a/manager/routes/routes.go
+++ b/manager/routes/routes.go
@@ -97,7 +97,6 @@ func InitAdmin(app *gin.Engine) {
 	api.GET("/check-caches", admin.CheckCaches)
 	api.PUT("/refresh-packages", admin.RefreshPackagesHandler)
 	api.PUT("/refresh-packages/:account", admin.RefreshPackagesAccountHandler)
-	api.PUT("/migrate_system_package", admin.MigrateSystemPackage)
 	api.GET("/sessions", admin.GetActiveSessionsHandler)
 	api.GET("/sessions/:search", admin.GetActiveSessionsHandler)
 	api.DELETE("/sessions/:pid", admin.TerminateSessionHandler)
diff --git a/turnpike/controllers/admin.go b/turnpike/controllers/admin.go
index a41aa4fb9..599bc1461 100644
--- a/turnpike/controllers/admin.go
+++ b/turnpike/controllers/admin.go
@@ -12,7 +12,6 @@ import (
 	"time"
 
 	"github.com/gin-gonic/gin"
-	"gorm.io/gorm"
 )
 
 type Session struct {
@@ -287,62 +286,3 @@ func getPprof(address, param, query string) ([]byte, error) {
 	}
 	return resBody, nil
 }
-
-// @Summary Migrate system_package data to system_package2
-// @Description Migrate system_package data to system_package2
-// @ID migrateSystemPackage
-// @Security RhIdentity
-// @Accept   json
-// @Produce  json
-// @Success 200 {object} string
-// @Failure 500 {object} map[string]interface{}
-// @Router /migrate_system_package [put]
-func MigrateSystemPackage(c *gin.Context) {
-	utils.LogInfo("starting system_package data migration")
-	var cnt int64
-	db := database.Db
-
-	db.Table("system_package2").Count(&cnt)
-	if cnt > 0 {
-		utils.LogInfo("System_package2 table is not empty")
-		c.JSON(http.StatusNoContent, "System_package2 table is not empty, nothing to do.")
-		return
-	}
-
-	// nolint:lll
-	go func() {
-		execQuery(db, "VACUUM ANALYZE system_package;")
-		execQuery(db, "ALTER TABLE system_package2 DROP CONSTRAINT system_package2_applicable_id_fkey;")
-		execQuery(db, "ALTER TABLE system_package2 DROP CONSTRAINT system_package2_installable_id_fkey;")
-		execQuery(db, "ALTER TABLE system_package2 DROP CONSTRAINT system_package2_name_id_fkey;")
-		execQuery(db, "ALTER TABLE system_package2 DROP CONSTRAINT system_package2_package_id_fkey;")
-		execQuery(db, "ALTER TABLE system_package2 DROP CONSTRAINT system_package2_rh_account_id_system_id_fkey;")
-		execQuery(db, "DROP INDEX system_package2_account_pkg_name_idx;")
-		execQuery(db, "DROP INDEX system_package2_package_id_idx;")
-
-		if err := db.Exec("CALL copy_system_packages();").Error; err != nil {
-			// truncate system_package2 table on failed migration
-			execQuery(db, "TRUNCATE TABLE system_package2;")
-			utils.LogError("err", err.Error(), "Migration failed")
-			return
-		}
-
-		execQuery(db, "ALTER TABLE system_package2 ADD CONSTRAINT system_package2_applicable_id_fkey FOREIGN KEY (applicable_id) REFERENCES package(id);")
-		execQuery(db, "ALTER TABLE system_package2 ADD CONSTRAINT system_package2_installable_id_fkey FOREIGN KEY (installable_id) REFERENCES package(id);")
-		execQuery(db, "ALTER TABLE system_package2 ADD CONSTRAINT system_package2_name_id_fkey FOREIGN KEY (name_id) REFERENCES package_name(id);")
-		execQuery(db, "ALTER TABLE system_package2 ADD CONSTRAINT system_package2_package_id_fkey FOREIGN KEY (package_id) REFERENCES package(id);")
-		execQuery(db, "ALTER TABLE system_package2 ADD CONSTRAINT system_package2_rh_account_id_system_id_fkey FOREIGN KEY (rh_account_id, system_id) REFERENCES system_platform (rh_account_id, id);")
-		execQuery(db, `CREATE INDEX IF NOT EXISTS system_package2_account_pkg_name_idx
-			ON system_package2 (rh_account_id, name_id) INCLUDE (system_id, package_id, installable_id, applicable_id);`)
-		execQuery(db, "CREATE INDEX IF NOT EXISTS system_package2_package_id_idx on system_package2 (package_id);")
-		utils.LogInfo("System_package migration completed")
-	}()
-	c.JSON(http.StatusOK, "Migration started")
-}
-
-func execQuery(db *gorm.DB, query string) {
-	err := db.Exec(query).Error
-	if err != nil {
-		utils.LogWarn("err", err.Error(), "query", query, "Exec of query failed.")
-	}
-}