Merge pull request #29 from codefresh-io/CR-4371

CR-4371

Author: elad-codefresh

VERSION

@@ -1 +1 @@
-0.31.1
+0.31.2

pkg/codefresh/codefresh.go

@@ -29,6 +29,7 @@ type (
 		Argo() ArgoAPI
 		Gitops() GitopsAPI
 		ArgoRuntime() IArgoRuntimeAPI
+		GitSource() IGitSourceAPI
 	}
 )
 
@@ -89,6 +90,10 @@ func (c *codefresh) ArgoRuntime() IArgoRuntimeAPI {
 	return newArgoRuntimeAPI(c)
 }
 
+func (c *codefresh) GitSource() IGitSourceAPI {
+	return newGitSourceAPI(c)
+}
+
 func (c *codefresh) requestAPI(opt *requestOptions) (*http.Response, error) {
 	return c.requestAPIWithContext(context.Background(), opt)
 }

pkg/codefresh/git-source.go

@@ -0,0 +1,92 @@
+package codefresh
+
+import (
+	"encoding/json"
+	"fmt"
+	"io/ioutil"
+
+	"github.com/codefresh-io/go-sdk/pkg/codefresh/model"
+)
+
+type (
+	IGitSourceAPI interface {
+		List(runtimeName string) ([]model.GitSource, error)
+	}
+
+	gitSource struct {
+		codefresh *codefresh
+	}
+
+	graphQlGitSourcesListResponse struct {
+		Data struct {
+			GitSources model.GitSourcePage
+		}
+		Errors []graphqlError
+	}
+)
+
+func newGitSourceAPI(codefresh *codefresh) IGitSourceAPI {
+	return &gitSource{codefresh: codefresh}
+}
+
+func (g *gitSource) List(runtimeName string) ([]model.GitSource, error) {
+	jsonData := map[string]interface{}{
+		"query": `query GitSources($runtime: String) {
+			gitSources(runtime: $runtime) {
+			  edges {
+				node {
+				  metadata {
+					name
+				  }
+				  self {
+					path
+					repoURL
+					status {
+					  syncStatus
+					  healthStatus
+					}
+				  }
+				}
+			  }
+			}
+		  }`,
+		"variables": map[string]interface{}{
+			"runtime": runtimeName,
+		},
+	}
+
+	response, err := g.codefresh.requestAPI(&requestOptions{
+		method: "POST",
+		path:   "/2.0/api/graphql",
+		body:   jsonData,
+	})
+	if err != nil {
+		fmt.Printf("The HTTP request failed with error %s\n", err)
+		return nil, err
+	}
+	defer response.Body.Close()
+
+	data, err := ioutil.ReadAll(response.Body)
+	if err != nil {
+		fmt.Printf("failed to read from response body")
+		return nil, err
+	}
+
+	res := graphQlGitSourcesListResponse{}
+	err = json.Unmarshal(data, &res)
+
+	if err != nil {
+		return nil, err
+	}
+
+	gitSources := make([]model.GitSource, len(res.Data.GitSources.Edges))
+	for i := range res.Data.GitSources.Edges {
+		gitSources[i] = *res.Data.GitSources.Edges[i].Node
+	}
+
+	if len(res.Errors) > 0 {
+		return nil, graphqlErrorResponse{errors: res.Errors}
+	}
+
+	return gitSources, nil
+}

pkg/codefresh/gitops.go

@@ -1,6 +1,8 @@
 package codefresh
 
-import "fmt"
+import (
+	"fmt"
+)
 
 type (
 	GitopsAPI interface {
@@ -103,7 +105,7 @@ type (
 		ParentApp    string                `json:"parentApp"`
 		Namespace    string                `json:"namespace"`
 		Server       string                `json:"server"`
-		Context      *string 			   `json:"context"`
+		Context      *string               `json:"context"`
 	}
 
 	EnvironmentActivity struct {
@@ -119,7 +121,7 @@ type (
 		HistoryId int64       `json:"historyId"`
 		Revision  string      `json:"revision, omitempty"`
 		Resources interface{} `json:"resources"`
-		Context   *string 	  `json:"context"`
+		Context   *string     `json:"context"`
 	}
 )