added component list

refactored code into codefresh.go

Author: ATGardner

pkg/codefresh/argo_runtime.go

@@ -31,8 +31,6 @@ type (
 	}
 )
 
-var qlEndPoint = "/2.0/api/graphql"
-
 func newArgoRuntimeAPI(codefresh *codefresh) IArgoRuntimeAPI {
 	return &argoRuntime{codefresh: codefresh}
 }

pkg/codefresh/codefresh.go

@@ -9,6 +9,7 @@ import (
 	"net/http"
 	"strings"
 
+	"github.com/codefresh-io/go-sdk/pkg/codefresh/model"
 	"github.com/google/go-querystring/query"
 )
 
@@ -30,9 +31,19 @@ type (
 		Gitops() GitopsAPI
 		ArgoRuntime() IArgoRuntimeAPI
 		GitSource() IGitSourceAPI
+		Component() IComponentAPI
+	}
+
+	graphqlResponse struct {
+		Data struct {
+			Runtimes model.RuntimePage
+		}
+		Errors []graphqlError
 	}
 )
 
+var qlEndPoint = "/2.0/api/graphql"
+
 func New(opt *ClientOptions) Codefresh {
 	httpClient := &http.Client{}
 	if opt.Client != nil {
@@ -94,6 +105,10 @@ func (c *codefresh) GitSource() IGitSourceAPI {
 	return newGitSourceAPI(c)
 }
 
+func (c *codefresh) Component() IComponentAPI {
+	return newComponentAPI(c)
+}
+
 func (c *codefresh) requestAPI(opt *requestOptions) (*http.Response, error) {
 	return c.requestAPIWithContext(context.Background(), opt)
 }
@@ -122,6 +137,25 @@ func (c *codefresh) requestAPIWithContext(ctx context.Context, opt *requestOptio
 	return response, nil
 }
 
+func (c *codefresh) graphqlAPI(ctx context.Context, body map[string]interface{}, res interface{}) error {
+	response, err := c.requestAPIWithContext(ctx, &requestOptions{
+		method: "POST",
+		path:   qlEndPoint,
+		body:   body,
+	})
+	if err != nil {
+		return fmt.Errorf("The HTTP request failed: %w", err)
+	}
+	defer response.Body.Close()
+
+	data, err := ioutil.ReadAll(response.Body)
+	if err != nil {
+		return fmt.Errorf("failed to read from response body: %w", err)
+	}
+
+	return json.Unmarshal(data, res)
+}
+
 func buildQSFromMap(qs map[string]string) string {
 	var arr = []string{}
 	for k, v := range qs {

pkg/codefresh/component.go

@@ -0,0 +1,72 @@
+package codefresh
+
+import (
+	"context"
+	"fmt"
+
+	"github.com/codefresh-io/go-sdk/pkg/codefresh/model"
+)
+
+type (
+	IComponentAPI interface {
+		List(ctx context.Context, runtimeName string) ([]model.Component, error)
+	}
+
+	component struct {
+		codefresh *codefresh
+	}
+
+	graphqlComponentsResponse struct {
+		Data struct {
+			Components model.ComponentPage
+		}
+		Errors []graphqlError
+	}
+)
+
+func newComponentAPI(codefresh *codefresh) IComponentAPI {
+	return &component{codefresh: codefresh}
+}
+
+func (r *component) List(ctx context.Context, runtimeName string) ([]model.Component, error) {
+	jsonData := map[string]interface{}{
+		"query": `
+			query Components($runtime: String!) {
+				components(runtime: $runtime) {
+					edges {
+						node {
+							metadata {
+								name
+							}
+							self {
+								status {
+									syncStatus
+									healthStatus
+								}
+							}
+						}
+					}
+				}
+			}`,
+		"variables": map[string]interface{}{
+			"runtime": runtimeName,
+		},
+	}
+
+	res := &graphqlComponentsResponse{}
+	err := r.codefresh.graphqlAPI(ctx, jsonData, res)
+	if err != nil {
+		return nil, fmt.Errorf("failed getting components list: %w", err)
+	}
+
+	if len(res.Errors) > 0 {
+		return nil, graphqlErrorResponse{errors: res.Errors}
+	}
+
+	components := make([]model.Component, len(res.Data.Components.Edges))
+	for i := range res.Data.Components.Edges {
+		components[i] = *res.Data.Components.Edges[i].Node
+	}
+
+	return components, nil
+}