fix: Set the path properly for calls to api-service (#470)

* fix: Set the path properly for calls to api-service Signed-off-by: Florian Bacher <[email protected]> * added test Signed-off-by: Florian Bacher <[email protected]> * removed debug output Signed-off-by: Florian Bacher <[email protected]>
keptn · Jun 3, 2022 · a3c50ce · a3c50ce
1 parent 669fb3d
commit a3c50ce
Show file tree

Hide file tree

Showing 2 changed files with 50 additions and 10 deletions.
diff --git a/pkg/api/utils/apiUtils.go b/pkg/api/utils/apiUtils.go
@@ -75,11 +75,7 @@ func (a *APIHandler) getHTTPClient() *http.Client {
 
 // SendEvent sends an event to Keptn
 func (a *APIHandler) SendEvent(event models.KeptnContextExtendedCE) (*models.EventContext, *models.Error) {
-	baseURL := a.getBaseURL()
-	if strings.HasSuffix(baseURL, "/"+shipyardControllerBaseURL) {
-		baseURL = strings.TrimSuffix(a.getBaseURL(), "/"+shipyardControllerBaseURL)
-		baseURL += "/api"
-	}
+	baseURL := a.getAPIServicePath()
 
 	bodyStr, err := event.ToJSON()
 	if err != nil {
@@ -158,11 +154,7 @@ func (a *APIHandler) DeleteService(project, service string) (*models.DeleteServi
 
 // GetMetadata retrieve keptn MetaData information
 func (a *APIHandler) GetMetadata() (*models.Metadata, *models.Error) {
-	baseURL := a.getBaseURL()
-	if strings.HasSuffix(baseURL, "/"+shipyardControllerBaseURL) {
-		baseURL = strings.TrimSuffix(a.getBaseURL(), "/"+shipyardControllerBaseURL)
-		baseURL += "/api"
-	}
+	baseURL := a.getAPIServicePath()
 
 	req, err := http.NewRequest("GET", a.Scheme+"://"+baseURL+v1MetadataPath, nil)
 	if err != nil {
@@ -198,3 +190,11 @@ func (a *APIHandler) GetMetadata() (*models.Metadata, *models.Error) {
 
 	return nil, handleErrStatusCode(resp.StatusCode, body)
 }
+
+func (a *APIHandler) getAPIServicePath() string {
+	baseURL := a.getBaseURL()
+	if strings.HasSuffix(baseURL, "/"+shipyardControllerBaseURL) {
+		baseURL = strings.TrimSuffix(a.getBaseURL(), "/"+shipyardControllerBaseURL)
+	}
+	return baseURL
+}
diff --git a/pkg/api/utils/apiUtils_test.go b/pkg/api/utils/apiUtils_test.go
@@ -0,0 +1,40 @@
+package api
+
+import (
+	"github.com/stretchr/testify/assert"
+	"testing"
+)
+
+func TestAPIHandler_getAPIServicePath(t *testing.T) {
+	type fields struct {
+		BaseURL string
+	}
+	tests := []struct {
+		name   string
+		fields fields
+		want   string
+	}{
+		{
+			name: "remove controlPlane path suffix",
+			fields: fields{
+				BaseURL: "my-api.sh/api/controlPlane",
+			},
+			want: "my-api.sh/api",
+		},
+		{
+			name: "don't modify anything for internal API calls",
+			fields: fields{
+				BaseURL: "api-service",
+			},
+			want: "api-service",
+		},
+	}
+	for _, tt := range tests {
+		t.Run(tt.name, func(t *testing.T) {
+			a := &APIHandler{
+				BaseURL: tt.fields.BaseURL,
+			}
+			assert.Equalf(t, tt.want, a.getAPIServicePath(), "getAPIServicePath()")
+		})
+	}
+}