Merge pull request #20 from codefresh-io/CR-5223

support runtime list

Author: oren-codefresh

VERSION

@@ -1 +1 @@
-0.26.2
+0.26.3

go.mod

@@ -2,6 +2,7 @@ module github.com/codefresh-io/go-sdk
 
 require (
 	github.com/BurntSushi/toml v0.3.1 // indirect
+	github.com/codefresh-io/argo-platform v1.13.0
 	github.com/dustin/go-humanize v1.0.0
 	github.com/google/go-querystring v1.1.0
 	github.com/inconshreveable/mousetrap v1.0.0 // indirect

go.sum

@@ -1,6 +1,8 @@
 github.com/BurntSushi/toml v0.3.1 h1:WXkYYl6Yr3qBf1K79EBnL4mak0OimBfB0XUf9Vl28OQ=
 github.com/BurntSushi/toml v0.3.1/go.mod h1:xHWCNGjB5oqiDr8zfno3MHue2Ht5sIBksp03qcyfWMU=
 github.com/armon/consul-api v0.0.0-20180202201655-eb2c6b5be1b6/go.mod h1:grANhF5doyWs3UAsr3K4I6qtAmlQcZDesFNEHPZAzj8=
+github.com/codefresh-io/argo-platform v1.13.0 h1:eWAWkxtO0nGZuekrQJsfFT5KfBMdWby0cOucy4yTExs=
+github.com/codefresh-io/argo-platform v1.13.0/go.mod h1:u/eLWAySJ1nRzNWnB5baeyIc5vqINghwYJvydU+EC3c=
 github.com/coreos/etcd v3.3.10+incompatible/go.mod h1:uF7uidLiAD3TWHmW31ZFd/JWoc32PjwdhPthX9715RE=
 github.com/coreos/go-etcd v2.0.0+incompatible/go.mod h1:Jez6KQU2B/sWsbdaef3ED8NzMklzPG4d5KIOhIy30Tk=
 github.com/coreos/go-semver v0.2.0/go.mod h1:nnelYz7RCh+5ahJtPPxZlU+153eP4D4r3EedlOD2RNk=

pkg/codefresh/argo_runtime.go

@@ -0,0 +1,81 @@
+package codefresh
+
+import (
+	"encoding/json"
+	"fmt"
+	"io/ioutil"
+
+	"github.com/codefresh-io/argo-platform/libs/ql/graph/model"
+)
+
+type (
+	IArgoRuntimeAPI interface {
+		List() ([]model.Runtime, error)
+	}
+	argoRuntime struct {
+		codefresh *codefresh
+	}
+	graphqlRuntimesResponse struct {
+		Data struct {
+			Runtimes model.RuntimePage
+		}
+		Errors []graphqlError
+	}
+)
+
+func newArgoRuntimeAPI(codefresh *codefresh) IArgoRuntimeAPI {
+	return &argoRuntime{codefresh: codefresh}
+}
+func (r *argoRuntime) List() ([]model.Runtime, error) {
+
+	jsonData := map[string]interface{}{
+		"query": ` 
+		{
+			runtimes{
+			  edges{
+				node {
+				  id
+				  namespace
+				  objectMeta {
+					name
+					description
+				  }
+				}
+			  }
+			}
+		  }
+        `,
+	}
+
+	response, err := r.codefresh.requestAPI(&requestOptions{
+		method: "POST",
+		path:   "/argo/api/graphql",
+		body:   jsonData,
+	})
+	defer response.Body.Close()
+	if err != nil {
+		fmt.Printf("The HTTP request failed with error %s\n", err)
+		return nil, err
+	}
+	data, err := ioutil.ReadAll(response.Body)
+	if err != nil {
+		fmt.Printf("failed to read from response body")
+		return nil, err
+	}
+	res := graphqlRuntimesResponse{}
+	err = json.Unmarshal(data, &res)
+	if err != nil {
+		return nil, err
+	}
+	runtimes := make([]model.Runtime, len(res.Data.Runtimes.Edges))
+	for i := range res.Data.Runtimes.Edges {
+		runtimes[i] = *res.Data.Runtimes.Edges[i].Node
+	}
+
+	if len(res.Errors) > 0 {
+		return nil, graphqlErrorResponse{errors: res.Errors}
+	}
+
+	return runtimes, nil
+
+}

pkg/codefresh/codefresh.go

@@ -28,6 +28,7 @@ type (
 		Users() UsersAPI
 		Argo() ArgoAPI
 		Gitops() GitopsAPI
+		ArgoRuntime() IArgoRuntimeAPI
 	}
 )
 
@@ -84,6 +85,10 @@ func (c *codefresh) Gitops() GitopsAPI {
 	return newGitopsAPI(c)
 }
 
+func (c *codefresh) ArgoRuntime() IArgoRuntimeAPI  {
+	return newArgoRuntimeAPI(c)
+}
+
 func (c *codefresh) requestAPI(opt *requestOptions) (*http.Response, error) {
 	return c.requestAPIWithContext(context.Background(), opt)
 }

pkg/codefresh/common.go

@@ -0,0 +1,40 @@
+package codefresh
+
+import (
+	"fmt"
+	"strings"
+
+)
+
+type graphqlError struct {
+	Message string
+	Locations [] struct {
+		Line int
+		Column int
+	}
+	Extensions struct {
+		Code string
+		Exception struct {
+			Stacktrace []string
+		}
+	}
+}
+
+type graphqlErrorResponse struct {
+	errors []graphqlError 
+	concatenatedErrors string
+}
+	
+
+func (e graphqlErrorResponse) Error() string {
+
+	if e.concatenatedErrors != "" {
+		return e.concatenatedErrors
+	}
+	var sb strings.Builder
+	for _, err := range e.errors {
+		sb.WriteString(fmt.Sprintln(err.Message))
+	}
+	e.concatenatedErrors = sb.String()
+	return e.concatenatedErrors
+}