Skip to content

Commit cb2bf5e

Browse files
committed
review after brian
1 parent 0b6bb97 commit cb2bf5e

File tree

3 files changed

+27
-19
lines changed

3 files changed

+27
-19
lines changed

pkg/lifecycle/logs.go

Lines changed: 7 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -14,11 +14,8 @@ type logs struct {
1414
filePath string
1515
}
1616

17-
// SEPARATOR is a standard separator for logs
18-
const SEPARATOR = "\n"
19-
20-
// ENDER is a standard end for the logged information
21-
const ENDER = "\n__________________________________________________________________\n"
17+
const separator = "\n"
18+
const ender = "\n__________________________________________________________________\n"
2219

2320
// createLogs creates a new log file and returns a logs struct with the file and file path
2421
func createLogs(fileName string) (*logs, error) {
@@ -51,7 +48,7 @@ func (l *logs) writeHEAD(versionRules *VersionRules, title string) {
5148
l.write(fmt.Sprintf("development branch: %s", versionRules.devBranch), "INFO")
5249
l.write(fmt.Sprintf("production branch: %s", versionRules.prodBranch), "INFO")
5350

54-
rules := make(map[string]string)
51+
rules := make(map[string]string, len(versionRules.rules))
5552
for k, v := range versionRules.rules {
5653
rules[fmt.Sprintf("%.1f", k)] = fmt.Sprintf("min: %s, max: %s", v.min, v.max)
5754
}
@@ -84,13 +81,13 @@ func (l *logs) write(data string, logType string) {
8481
logrus.Errorf("Error while writing logs: %s", err)
8582
}
8683
case "SEPARATE":
87-
fmt.Printf(SEPARATOR)
88-
if _, err := l.file.WriteString(SEPARATOR); err != nil {
84+
fmt.Printf(separator)
85+
if _, err := l.file.WriteString(separator); err != nil {
8986
logrus.Errorf("Error while writing logs: %s", err)
9087
}
9188
case "END":
92-
fmt.Printf(ENDER)
93-
if _, err := l.file.WriteString("\n" + ENDER + "\n"); err != nil {
89+
fmt.Printf(ender)
90+
if _, err := l.file.WriteString("\n" + ender + "\n"); err != nil {
9491
logrus.Errorf("Error while writing logs: %s", err)
9592
}
9693
default:

pkg/lifecycle/status.go

Lines changed: 12 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -43,7 +43,11 @@ func (ld *Dependencies) getStatus() (*Status, error) {
4343
}
4444

4545
// Separate the assets to be released from the assets to be forward ported after the comparison
46-
status.separateReleaseFromForwardPort()
46+
err = status.separateReleaseFromForwardPort()
47+
if err != nil {
48+
logrus.Errorf("failed to separate releases from forward-ports: %v", err)
49+
return status, fmt.Errorf("failed to separate releases from forward-ports: %v", err)
50+
}
4751

4852
return status, nil
4953
}
@@ -350,13 +354,17 @@ func checkIfVersionIsReleased(version string, releasedVersions []Asset) bool {
350354
}
351355

352356
// separateReleaseFromForwardPort will separate the assets to be released from the assets to be forward ported, the assets were loaded previously by listProdAndDevAssets function.
353-
func (s *Status) separateReleaseFromForwardPort() {
357+
func (s *Status) separateReleaseFromForwardPort() error {
354358
assetsToBeReleased := make(map[string][]Asset)
355359
assetsToBeForwardPorted := make(map[string][]Asset)
356360

357361
for asset, versions := range s.assetsNotReleasedInLifecycle {
358362
for _, version := range versions {
359-
if toRelease := s.ld.VR.CheckChartVersionToRelease(version.version); toRelease {
363+
toRelease, err := s.ld.VR.CheckChartVersionToRelease(version.version)
364+
if err != nil {
365+
return err
366+
}
367+
if toRelease {
360368
assetsToBeReleased[asset] = append(assetsToBeReleased[asset], version)
361369
} else {
362370
assetsToBeForwardPorted[asset] = append(assetsToBeForwardPorted[asset], version)
@@ -367,5 +375,5 @@ func (s *Status) separateReleaseFromForwardPort() {
367375
s.assetsToBeReleased = assetsToBeReleased
368376
s.assetsToBeForwardPorted = assetsToBeForwardPorted
369377

370-
return
378+
return nil
371379
}

pkg/lifecycle/versions.rules.go

Lines changed: 8 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -4,6 +4,8 @@ import (
44
"fmt"
55
"strconv"
66
"strings"
7+
8+
"github.com/sirupsen/logrus"
79
)
810

911
// ProductionBranchPrefix is the official prefix for the production branch
@@ -138,10 +140,11 @@ func (vr *VersionRules) CheckChartVersionForLifecycle(chartVersion string) bool
138140
}
139141

140142
// CheckChartVersionToRelease will return if the current versyion being analyzed is the one to be released or not
141-
func (vr *VersionRules) CheckChartVersionToRelease(chartVersion string) bool {
142-
chartVersionInt, _ := strconv.Atoi(strings.Split(chartVersion, ".")[0])
143-
if chartVersionInt == (vr.maxVersion - 1) {
144-
return true
143+
func (vr *VersionRules) CheckChartVersionToRelease(chartVersion string) (bool, error) {
144+
chartVersionInt, err := strconv.Atoi(strings.Split(chartVersion, ".")[0])
145+
if err != nil {
146+
logrus.Errorf("failed to check version to release for chartVersion:%s with error:%v", chartVersion, err)
147+
return false, err
145148
}
146-
return false
149+
return chartVersionInt == (vr.maxVersion - 1), nil
147150
}

0 commit comments

Comments
 (0)