Merge branch 'master' of github.com:codefresh-io/go-sdk into CR-5460

� Conflicts:
�	VERSION
�	pkg/codefresh/gitops.go

Author: pasha-codefresh

.goreleaser.yml

@@ -1 +1 @@
-0.27.0
+0.26.6

VERSION

@@ -1,46 +1,27 @@
 version: '1.0'
 
 stages:
+- Prepare
 - Release
 
-mode: parallel
-
 steps:
 
-  CreatingGitTag:
-    title: Push tag to git
-    image: codefresh/cli
-    stage: Release
-    commands:
-    - export VERSION=$(cat VERSION)
-    - export OLD_ORIGIN=$(git remote get-url origin)
-    - git remote rm origin
-    - git remote add origin https://${{GITHUB_TOKEN}}@github.com/codefresh-io/go-sdk.git
-    - git tag v$VERSION
-    - git push --tags
-    - git remote rm origin
-    - git remote add origin $OLD_ORIGIN
-    fail_fast: false
-    when:
-      steps:
-      - name: main_clone
-      branch:
-        only:
-        - master
+  main_clone:
+    stage: Prepare
+    title: clone repository
+    type: git-clone
+    git: cf_github
+    repo: ${{CF_REPO_OWNER}}/${{CF_REPO_NAME}}
+    revision: ${{CF_BRANCH}}
 
   ReleasingBinaries:
     title: Create release in Github
-    image: goreleaser/goreleaser
+    image: quay.io/codefresh/golang-ci-helper:latest
     stage: Release
-    fail_fast: false
     commands:
-    - go mod download
-    - goreleaser release -f .goreleaser.yml --rm-dist --skip-validate
+    - export VERSION=$(cat VERSION)
+    - gh release create --repo ${{CF_REPO_OWNER}}/${{CF_REPO_NAME}} -t $VERSION -n $VERSION $VERSION
     when:
-      steps:
-      - name: CreatingGitTag
-        on:
-        - finished
       branch:
         only:
-        - master
+        - master

codefresh.yaml

@@ -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
@@ -11,6 +12,8 @@ require (
 	github.com/spf13/afero v1.2.0 // indirect
 	github.com/spf13/cobra v0.0.3
 	github.com/spf13/viper v1.3.1
+	github.com/stretchr/objx v0.3.0 // indirect
+	github.com/stretchr/testify v1.3.0
 	golang.org/x/sys v0.0.0-20181228144115-9a3f9b0469bb // indirect
 	gopkg.in/yaml.v2 v2.2.2
 )

go.mod

@@ -1,9 +1,12 @@
 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=
+github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
 github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c=
 github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
 github.com/dustin/go-humanize v1.0.0 h1:VSnTsYCnlFHaM2/igO1h6X3HA71jcobQuxemgkq4zYo=
@@ -45,8 +48,12 @@ github.com/spf13/pflag v1.0.3 h1:zPAT6CGy6wXeQ7NtTnaTerfKOsV6V6F8agHXFiazDkg=
 github.com/spf13/pflag v1.0.3/go.mod h1:DYY7MBk1bdzusC3SYhjObp+wFpr4gzcvqqNjLnInEg4=
 github.com/spf13/viper v1.3.1 h1:5+8j8FTpnFV4nEImW/ofkzEt8VoOiLXxdYIDsB73T38=
 github.com/spf13/viper v1.3.1/go.mod h1:ZiWeW+zYFKm7srdB9IoDzzZXaJaI5eL9QjNiN/DMA2s=
-github.com/stretchr/testify v1.2.2 h1:bSDNvY7ZPG5RlJ8otE/7V6gMiyenm9RtJ7IUVIAoJ1w=
+github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME=
+github.com/stretchr/objx v0.3.0 h1:NGXK3lHquSN08v5vWalVI/L8XU9hdzE/G6xsrze47As=
+github.com/stretchr/objx v0.3.0/go.mod h1:qt09Ya8vawLte6SNmTgCsAVtYtaKzEcn8ATUoHMkEqE=
 github.com/stretchr/testify v1.2.2/go.mod h1:a8OnRcib4nhh0OaRAV+Yts87kKdq0PP7pXfy6kDkUVs=
+github.com/stretchr/testify v1.3.0 h1:TivCn/peBQ7UY8ooIcPgZFpTNSz0Q2U6UrFlUfqbe0Q=
+github.com/stretchr/testify v1.3.0/go.mod h1:M5WIy9Dh21IEIfnGCwXGc5bZfKNJtfHm1UVUgZn+9EI=
 github.com/ugorji/go/codec v0.0.0-20181204163529-d75b2dcb6bc8/go.mod h1:VFNgLljTbGfSG7qAOspJ7OScBnGdDN/yBr0sguwnwf0=
 github.com/xordataexchange/crypt v0.0.3-0.20170626215501-b2862e3d0a77/go.mod h1:aYKd//L2LvnjZzWKhF00oedf4jCCReLcmhLdhm1A27Q=
 golang.org/x/crypto v0.0.0-20181203042331-505ab145d0a9/go.mod h1:6SG95UA2DQfeDnfUPMdvaQW0Q7yPrPDi9nlGo2tz2b4=

go.sum

@@ -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/argo_runtime.go

@@ -2,14 +2,20 @@ package codefresh
 
 import (
 	"bytes"
+	"context"
 	"encoding/json"
 	"fmt"
-	"github.com/google/go-querystring/query"
 	"io/ioutil"
 	"net/http"
 	"strings"
+
+	"github.com/google/go-querystring/query"
 )
 
+//go:generate mockery -name Codefresh -filename codefresh.go
+
+//go:generate mockery -name UsersAPI -filename users.go
+
 type (
 	Codefresh interface {
 		Pipelines() IPipelineAPI
@@ -19,8 +25,10 @@ type (
 		Progresses() IProgressAPI
 		Clusters() IClusterAPI
 		Contexts() IContextAPI
+		Users() UsersAPI
 		Argo() ArgoAPI
 		Gitops() GitopsAPI
+		ArgoRuntime() IArgoRuntimeAPI
 	}
 )
 
@@ -41,6 +49,10 @@ func (c *codefresh) Pipelines() IPipelineAPI {
 	return newPipelineAPI(c)
 }
 
+func (c *codefresh) Users() UsersAPI {
+	return newUsersAPI(c)
+}
+
 func (c *codefresh) Tokens() ITokenAPI {
 	return newTokenAPI(c)
 }
@@ -73,7 +85,15 @@ 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)
+}
+
+func (c *codefresh) requestAPIWithContext(ctx context.Context, opt *requestOptions) (*http.Response, error) {
 	var body []byte
 	finalURL := fmt.Sprintf("%s%s", c.host, opt.path)
 	if opt.qs != nil {
@@ -82,7 +102,10 @@ func (c *codefresh) requestAPI(opt *requestOptions) (*http.Response, error) {
 	if opt.body != nil {
 		body, _ = json.Marshal(opt.body)
 	}
-	request, err := http.NewRequest(opt.method, finalURL, bytes.NewBuffer(body))
+	request, err := http.NewRequestWithContext(ctx, opt.method, finalURL, bytes.NewBuffer(body))
+	if err != nil {
+		return nil, err
+	}
 	request.Header.Set("Authorization", c.token)
 	request.Header.Set("Content-Type", "application/json")
 

pkg/codefresh/codefresh.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
+}

pkg/codefresh/common.go

@@ -7,7 +7,7 @@ type (
 		GetDefaultGitContext() (error, *ContextPayload)
 	}
 
-	context struct {
+	contexts struct {
 		codefresh *codefresh
 	}
 
@@ -42,10 +42,10 @@ type (
 )
 
 func newContextAPI(codefresh *codefresh) IContextAPI {
-	return &context{codefresh}
+	return &contexts{codefresh}
 }
 
-func (c context) GetGitContexts() (error, *[]ContextPayload) {
+func (c contexts) GetGitContexts() (error, *[]ContextPayload) {
 	var result []ContextPayload
 
 	qs := GitContextsQs{
@@ -67,7 +67,7 @@ func (c context) GetGitContexts() (error, *[]ContextPayload) {
 	return err, &result
 }
 
-func (c context) GetGitContextByName(name string) (error, *ContextPayload) {
+func (c contexts) GetGitContextByName(name string) (error, *ContextPayload) {
 	var result ContextPayload
 	var qs = map[string]string{
 		"decrypt": "true",
@@ -87,7 +87,7 @@ func (c context) GetGitContextByName(name string) (error, *ContextPayload) {
 	return nil, &result
 }
 
-func (c context) GetDefaultGitContext() (error, *ContextPayload) {
+func (c contexts) GetDefaultGitContext() (error, *ContextPayload) {
 	var result ContextPayload
 
 	resp, err := c.codefresh.requestAPI(&requestOptions{