#1549 Get all projects helper method (#152)

keptn · Apr 29, 2020 · 17c6026 · 17c6026
1 parent 846f2be
commit 17c6026
Show file tree

Hide file tree

Showing 3 changed files with 63 additions and 1 deletion.
diff --git a/pkg/api/utils/projectUtils.go b/pkg/api/utils/projectUtils.go
@@ -1,9 +1,12 @@
 package api
 
 import (
+	"crypto/tls"
 	"encoding/json"
+	"errors"
 	"io/ioutil"
 	"net/http"
+	"net/url"
 	"strings"
 
 	"github.com/keptn/go-utils/pkg/api/models"
@@ -94,7 +97,64 @@ func (p *ProjectHandler) DeleteProject(project models.Project) (*models.EventCon
 
 // GetProject returns a project
 func (p *ProjectHandler) GetProject(project models.Project) (*models.Project, *models.Error) {
-	return getProject(p.Scheme+"://"+p.getBaseURL()+"/v1/project/"+project.ProjectName, p)
+	return getProject(p.Scheme+"://"+p.getBaseURL()+"/configuration-service/v1/project/"+project.ProjectName, p)
+}
+
+// GetProjects returns a project
+func (p *ProjectHandler) GetAllProjects() ([]*models.Project, error) {
+	http.DefaultTransport.(*http.Transport).TLSClientConfig = &tls.Config{InsecureSkipVerify: true}
+	projects := []*models.Project{}
+
+	nextPageKey := ""
+
+	for {
+		url, err := url.Parse(p.Scheme + "://" + p.getBaseURL() + "/configuration-service/v1/project/")
+		if err != nil {
+			return nil, err
+		}
+		q := url.Query()
+		if nextPageKey != "" {
+			q.Set("nextPageKey", nextPageKey)
+			url.RawQuery = q.Encode()
+		}
+		req, err := http.NewRequest("GET", url.String(), nil)
+		req.Header.Set("Content-Type", "application/json")
+		addAuthHeader(req, p)
+
+		resp, err := p.HTTPClient.Do(req)
+		if err != nil {
+			return nil, err
+		}
+		defer resp.Body.Close()
+
+		body, err := ioutil.ReadAll(resp.Body)
+		if err != nil {
+			return nil, err
+		}
+
+		if resp.StatusCode == 200 {
+			var received models.Projects
+			err = json.Unmarshal(body, &received)
+			if err != nil {
+				return nil, err
+			}
+			projects = append(projects, received.Projects...)
+
+			if received.NextPageKey == "" || received.NextPageKey == "0" {
+				break
+			}
+			nextPageKey = received.NextPageKey
+		} else {
+			var respErr models.Error
+			err = json.Unmarshal(body, &respErr)
+			if err != nil {
+				return nil, err
+			}
+			return nil, errors.New("Response Error Code: " + string(respErr.Code) + " Message: " + *respErr.Message)
+		}
+	}
+
+	return projects, nil
 }
 
 func getProject(uri string, api APIService) (*models.Project, *models.Error) {

diff --git a/pkg/api/utils/serviceUtils.go b/pkg/api/utils/serviceUtils.go
@@ -109,6 +109,7 @@ func (s *ServiceHandler) GetAllServices(project string, stage string) ([]*models
 		q := url.Query()
 		if nextPageKey != "" {
 			q.Set("nextPageKey", nextPageKey)
+			url.RawQuery = q.Encode()
 		}
 		req, err := http.NewRequest("GET", url.String(), nil)
 		req.Header.Set("Content-Type", "application/json")

diff --git a/pkg/api/utils/stageUtils.go b/pkg/api/utils/stageUtils.go
@@ -97,6 +97,7 @@ func (s *StageHandler) GetAllStages(project string) ([]*models.Stage, error) {
 		q := url.Query()
 		if nextPageKey != "" {
 			q.Set("nextPageKey", nextPageKey)
+			url.RawQuery = q.Encode()
 		}
 		req, err := http.NewRequest("GET", url.String(), nil)
 		req.Header.Set("Content-Type", "application/json")