From e9192e75ea3ff85f41bd6721a90c04ed8e0c6804 Mon Sep 17 00:00:00 2001
From: ssongliu <73214554+ssongliu@users.noreply.github.com>
Date: Tue, 1 Jul 2025 22:29:33 +0800
Subject: [PATCH] fix: Fix file existence check when deleting node upgrade
 records (#9365)

---
 core/app/repo/upgrade_log.go | 7 +++++++
 1 file changed, 7 insertions(+)

diff --git a/core/app/repo/upgrade_log.go b/core/app/repo/upgrade_log.go
index 9e0b129dc..6e3df813f 100644
--- a/core/app/repo/upgrade_log.go
+++ b/core/app/repo/upgrade_log.go
@@ -16,6 +16,7 @@ type IUpgradeLogRepo interface {
 	Delete(opts ...global.DBOption) error
 
 	WithByNodeID(nodeID uint) global.DBOption
+	WithByUpgradeVersion(oldVersion, newVersion string) global.DBOption
 }
 
 func NewIUpgradeLogRepo() IUpgradeLogRepo {
@@ -79,3 +80,9 @@ func (c *UpgradeLogRepo) WithByNodeID(nodeID uint) global.DBOption {
 		return g.Where("node_id = ?", nodeID)
 	}
 }
+
+func (c *UpgradeLogRepo) WithByUpgradeVersion(oldVersion, newVersion string) global.DBOption {
+	return func(g *gorm.DB) *gorm.DB {
+		return g.Where("old_version = ? AND new_version = ?", oldVersion, newVersion)
+	}
+}