Skip to content
This repository has been archived by the owner on Dec 21, 2023. It is now read-only.

chore(shipyard-controller): Do not interpret absence of configurationChange property as an error (#5979) #5982

Merged
merged 1 commit into from Nov 12, 2021
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Jump to
Jump to file
Failed to load files.
Diff view
Diff view
6 changes: 3 additions & 3 deletions shipyard-controller/common/keptn_helpers.go
Expand Up @@ -182,9 +182,9 @@ func CreateEventWithPayload(keptnContext, triggeredID, eventType string, payload
return event
}

func ExtractImageOfDeploymentEvent(deploymentTriggeredEventData keptnv2.DeploymentTriggeredEventData) (string, error) {
func ExtractImageOfDeploymentEvent(deploymentTriggeredEventData keptnv2.DeploymentTriggeredEventData) string {
if imageValue, ok := deploymentTriggeredEventData.ConfigurationChange.Values["image"].(string); ok {
return imageValue, nil
return imageValue
}
return "", errors.New("could not extract image name of event: could not find property configurationChange.Values['image'] of type string")
return ""
}
25 changes: 9 additions & 16 deletions shipyard-controller/common/keptn_helpers_test.go
Expand Up @@ -3,6 +3,7 @@ package common
import (
keptnv2 "github.com/keptn/go-utils/pkg/lib/v0_2_0"
"github.com/stretchr/testify/assert"
"github.com/stretchr/testify/require"
"os"
"testing"
)
Expand Down Expand Up @@ -85,10 +86,9 @@ func TestExtractImageOfDeploymentEvent(t *testing.T) {
eventData keptnv2.DeploymentTriggeredEventData
}
tests := []struct {
name string
args args
want string
wantErr bool
name string
args args
want string
}{
{
name: "extract image property from correctly structured event",
Expand All @@ -101,8 +101,7 @@ func TestExtractImageOfDeploymentEvent(t *testing.T) {
},
},
},
want: "my-image",
wantErr: false,
want: "my-image",
},
{
name: "image property has different type than expected",
Expand All @@ -118,20 +117,14 @@ func TestExtractImageOfDeploymentEvent(t *testing.T) {
},
},
},
want: "",
wantErr: true,
want: "",
},
}
for _, tt := range tests {
t.Run(tt.name, func(t *testing.T) {
got, err := ExtractImageOfDeploymentEvent(tt.args.eventData)
if (err != nil) != tt.wantErr {
t.Errorf("ExtractImageOfDeploymentEvent() error = %v, wantErr %v", err, tt.wantErr)
return
}
if got != tt.want {
t.Errorf("ExtractImageOfDeploymentEvent() got = %v, want %v", got, tt.want)
}
got := ExtractImageOfDeploymentEvent(tt.args.eventData)

require.Equal(t, tt.want, got)
})
}
}
Expand Down
5 changes: 1 addition & 4 deletions shipyard-controller/db/mongodb_project_mv_repo.go
Expand Up @@ -493,10 +493,7 @@ func (mv *MongoDBProjectMVRepo) UpdateEventOfService(e models.Event) error {
return errors.New("unable to decode deployment.triggered event data: " + err.Error())
}

deployedImage, err := common.ExtractImageOfDeploymentEvent(*triggeredData)
if err != nil {
return fmt.Errorf("could not determine deployed image: %s", err.Error())
}
deployedImage := common.ExtractImageOfDeploymentEvent(*triggeredData)
service.DeployedImage = deployedImage
}
return nil
Expand Down
5 changes: 1 addition & 4 deletions shipyard-controller/handler/sequence_migrator.go
Expand Up @@ -261,10 +261,7 @@ func processTaskEventTaskEvent(scope models.EventScope, event models.Event, stag
if err := keptnv2.Decode(event.Data, deploymentTriggeredEventData); err != nil {
return nil, fmt.Errorf("could not decode deployment.triggered event data: %s", err.Error())
}
deployedImage, err := common.ExtractImageOfDeploymentEvent(*deploymentTriggeredEventData)
if err != nil {
return nil, fmt.Errorf("could not determine deployed image: %s", err.Error())
}
deployedImage := common.ExtractImageOfDeploymentEvent(*deploymentTriggeredEventData)
stageState.Image = deployedImage
}

Expand Down
6 changes: 2 additions & 4 deletions shipyard-controller/handler/sequencehooks/sequencestate.go
Expand Up @@ -259,10 +259,8 @@ func (smv *SequenceStateMaterializedView) updateImageOfSequence(event models.Eve
return fmt.Errorf("could not decode deployment.triggered event data: %s", err.Error())
}

deployedImage, err := common.ExtractImageOfDeploymentEvent(*deploymentTriggeredEventData)
if err != nil {
return fmt.Errorf("could not determine deployed image: %s", err.Error())
}
deployedImage := common.ExtractImageOfDeploymentEvent(*deploymentTriggeredEventData)

eventScope, err := models.NewEventScope(event)
if err != nil {
return fmt.Errorf("could not determine event scope: %s", err.Error())
Expand Down