Skip to content

Commit

Permalink
Use only one set of constants.
Browse files Browse the repository at this point in the history
  • Loading branch information
woblerr committed Aug 17, 2023
1 parent 98e1f40 commit 3f5535a
Show file tree
Hide file tree
Showing 5 changed files with 18 additions and 22 deletions.
14 changes: 7 additions & 7 deletions cmd/backup_delete.go
Original file line number Diff line number Diff line change
Expand Up @@ -188,9 +188,9 @@ func backupDeleteDBPluginFunc(backupName string, backupData gpbckpconfig.BackupC
gplog.Error(stderr)
}
if errdel != nil {
err = updateDeleteStatus(backupName, deleteStatusPluginFailed, hDB)
err = updateDeleteStatus(backupName, gpbckpconfig.DateDeletedPluginFailed, hDB)
if err != nil {
gplog.Error(errtext.ErrorTextUnableSetBackupStatus(deleteStatusPluginFailed, backupName, err))
gplog.Error(errtext.ErrorTextUnableSetBackupStatus(gpbckpconfig.DateDeletedPluginFailed, backupName, err))
}
gplog.Error(errtext.ErrorTextUnableDeleteBackup(backupName, errdel))
return errdel
Expand All @@ -202,7 +202,7 @@ func backupDeleteDBPluginFunc(backupName string, backupData gpbckpconfig.BackupC
return errdel
}
} else {
if backupDateDeleted == deleteStatusInProgress {
if backupDateDeleted == gpbckpconfig.DateDeletedInProgress {
gplog.Warn(errtext.ErrorTextBackupInProgress(backupName, errtext.ErrorBackupDeleteInProgressError()))
return errtext.ErrorBackupDeleteInProgressError()
} else {
Expand Down Expand Up @@ -296,21 +296,21 @@ func backupDeleteFilePluginFunc(backupData gpbckpconfig.BackupConfig, parseHData
gplog.Error(stderr)
}
if errdel != nil {
err = parseHData.UpdateBackupConfigDateDeleted(backupData.Timestamp, deleteStatusPluginFailed)
err = parseHData.UpdateBackupConfigDateDeleted(backupData.Timestamp, gpbckpconfig.DateDeletedPluginFailed)
if err != nil {
gplog.Error(errtext.ErrorTextUnableSetBackupStatus(deleteStatusPluginFailed, backupData.Timestamp, err))
gplog.Error(errtext.ErrorTextUnableSetBackupStatus(gpbckpconfig.DateDeletedPluginFailed, backupData.Timestamp, err))
}
gplog.Error(errtext.ErrorTextUnableDeleteBackup(backupData.Timestamp, errdel))
return errdel
}
gplog.Info(stdout)
err = parseHData.UpdateBackupConfigDateDeleted(backupData.Timestamp, deleteStatusPluginFailed)
err = parseHData.UpdateBackupConfigDateDeleted(backupData.Timestamp, gpbckpconfig.DateDeletedPluginFailed)
if err != nil {
gplog.Error(errtext.ErrorTextUnableSetBackupStatus(dateDeleted, backupData.Timestamp, err))
return err
}
} else {
if backupDateDeleted == deleteStatusInProgress {
if backupDateDeleted == gpbckpconfig.DateDeletedInProgress {
gplog.Warn(errtext.ErrorTextBackupInProgress(backupData.Timestamp, errtext.ErrorBackupDeleteInProgressError()))
return errtext.ErrorBackupDeleteInProgressError()
} else {
Expand Down
12 changes: 6 additions & 6 deletions cmd/backup_info.go
Original file line number Diff line number Diff line change
Expand Up @@ -166,18 +166,18 @@ func getBackupNames(showD, showF, sAll bool, historyDB *sql.DB) ([]string, error
case showD:
getBackupsQuery += " WHERE status != '" + failureStatus + "'" +
" AND date_deleted NOT IN ('', '" +
deleteStatusInProgress + "', '" +
deleteStatusPluginFailed + "', '" +
deleteStatusLocalFailed + "')" + orderBy
gpbckpconfig.DateDeletedInProgress + "', '" +
gpbckpconfig.DateDeletedPluginFailed + "', '" +
gpbckpconfig.DateDeletedLocalFailed + "')" + orderBy

case showF:
getBackupsQuery += " WHERE status = '" + failureStatus + "'" + orderBy
default:
getBackupsQuery += " WHERE status != '" + failureStatus + "'" +
" AND date_deleted IN ('', '" +
deleteStatusInProgress + "', '" +
deleteStatusPluginFailed + "', '" +
deleteStatusLocalFailed + "')" + orderBy
gpbckpconfig.DateDeletedInProgress + "', '" +
gpbckpconfig.DateDeletedPluginFailed + "', '" +
gpbckpconfig.DateDeletedLocalFailed + "')" + orderBy
}
backupListRow, err := historyDB.Query(getBackupsQuery)
if err != nil {
Expand Down
4 changes: 0 additions & 4 deletions cmd/constants.go
Original file line number Diff line number Diff line change
Expand Up @@ -5,10 +5,6 @@ const (

deleteBackupPluginCommand = "delete_backup"

deleteStatusInProgress = "In progress"
deleteStatusPluginFailed = "Plugin Backup Delete Failed"
deleteStatusLocalFailed = "Local Delete Failed"

failureStatus = "Failure"

historyFileNameBaseConst = "gpbackup_history"
Expand Down
2 changes: 1 addition & 1 deletion cmd/wrapers.go
Original file line number Diff line number Diff line change
Expand Up @@ -115,7 +115,7 @@ func getCurrentTimestamp() string {
}

func isBackupActive(dateDeleted string) bool {
return (dateDeleted != "" || dateDeleted == deleteStatusPluginFailed || dateDeleted == deleteStatusLocalFailed)
return (dateDeleted != "" || dateDeleted == gpbckpconfig.DateDeletedPluginFailed || dateDeleted == gpbckpconfig.DateDeletedLocalFailed)
}

func checkFullPath(path string) error {
Expand Down
8 changes: 4 additions & 4 deletions gpbckpconfig/struct.go
Original file line number Diff line number Diff line change
Expand Up @@ -67,9 +67,9 @@ const (
objectFilteringIncludeTable = "include-table"
objectFilteringExcludeTable = "exclude-table"
// Date deleted types.
dateDeletedInProgress = "In progress"
dateDeletedPluginFailed = "Plugin Backup Delete Failed"
dateDeletedLocalFailed = "Local Delete Failed"
DateDeletedInProgress = "In progress"
DateDeletedPluginFailed = "Plugin Backup Delete Failed"
DateDeletedLocalFailed = "Local Delete Failed"
)

// GetBackupType Get backup type.
Expand Down Expand Up @@ -178,7 +178,7 @@ func (backupConfig BackupConfig) GetBackupDuration() (float64, error) {
// In all other cases, an error is returned.
func (backupConfig BackupConfig) GetBackupDateDeleted() (string, error) {
switch backupConfig.DateDeleted {
case "", dateDeletedInProgress, dateDeletedPluginFailed, dateDeletedLocalFailed:
case "", DateDeletedInProgress, DateDeletedPluginFailed, DateDeletedLocalFailed:
return backupConfig.DateDeleted, nil
default:
t, err := time.Parse(Layout, backupConfig.DateDeleted)
Expand Down

0 comments on commit 3f5535a

Please sign in to comment.