Skip to content

Commit c42aa28

Browse files
committed
return Zos4Version from db
1 parent 546d03a commit c42aa28

File tree

2 files changed

+11
-11
lines changed

2 files changed

+11
-11
lines changed

node-registrar/pkg/db/version.go

Lines changed: 10 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -2,36 +2,36 @@ package db
22

33
import (
44
"errors"
5+
"reflect"
56

67
"gorm.io/gorm"
78
)
89

9-
func (db *Database) SetZOSVersion(version string) error {
10+
func (db *Database) SetZOSVersion(version ZosVersion) error {
1011
var current ZosVersion
11-
result := db.gormDB.Where(ZosVersion{Key: ZOS4VersionKey}).Attrs(ZosVersion{Version: version}).FirstOrCreate(&current)
12+
result := db.gormDB.Where(ZosVersion{Key: ZOS4VersionKey}).Attrs(ZosVersion{Version: version.Version}).FirstOrCreate(&current)
1213

1314
if result.Error != nil {
1415
return result.Error
1516
}
1617

1718
if result.RowsAffected == 0 {
18-
if current.Version == version {
19+
if reflect.DeepEqual(current, version) {
1920
return ErrVersionAlreadySet
2021
}
2122
return db.gormDB.Model(&current).
2223
Select("version").
23-
Update("version", version).Error
24+
Updates(version).Error
2425
}
2526
return nil
2627
}
2728

28-
func (db *Database) GetZOSVersion() (string, error) {
29-
var setting ZosVersion
30-
if err := db.gormDB.Where("key = ?", "zos_4").First(&setting).Error; err != nil {
29+
func (db *Database) GetZOSVersion() (version ZosVersion, err error) {
30+
if err := db.gormDB.Where("key = ?", "zos_4").First(&version).Error; err != nil {
3131
if errors.Is(err, gorm.ErrRecordNotFound) {
32-
return "", ErrRecordNotFound
32+
return version, ErrRecordNotFound
3333
}
34-
return "", err
34+
return version, err
3535
}
36-
return setting.Version, nil
36+
return version, nil
3737
}

node-registrar/pkg/server/handlers.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -729,7 +729,7 @@ func (s *Server) setZOSVersionHandler(c *gin.Context) {
729729
return
730730
}
731731

732-
if err := s.db.SetZOSVersion(req.Version); err != nil {
732+
if err := s.db.SetZOSVersion(db.ZosVersion{Version: req.Version, SafeToUpgrade: req.SafeToUpgrade}); err != nil {
733733
status := http.StatusInternalServerError
734734
if err.Error() == "version already set" {
735735
status = http.StatusConflict

0 commit comments

Comments
 (0)