old and new mutations

Author: elad-codefresh

pkg/codefresh/argo_runtime.go

@@ -10,6 +10,8 @@ import (
 type (
 	IRuntimeAPI interface {
 		CreateUsingOldMutation(ctx context.Context, runtimeName, cluster, runtimeVersion, ingressHost string, componentNames []string) (*model.RuntimeCreationResponse, error)
+		CreateUsingNewMutation(ctx context.Context, opts *model.RuntimeInstallationArgs) (*model.RuntimeCreationResponse, error)
+
 		Get(ctx context.Context, name string) (*model.Runtime, error)
 		List(ctx context.Context) ([]model.Runtime, error)
 		Delete(ctx context.Context, runtimeName string) (int, error)
@@ -86,6 +88,36 @@ func (r *argoRuntime) CreateUsingOldMutation(ctx context.Context, runtimeName, c
 	return &res.Data.Runtime, nil
 }
 
+func (r *argoRuntime) CreateUsingNewMutation(ctx context.Context, opts *model.RuntimeInstallationArgs) (*model.RuntimeCreationResponse, error) {
+	jsonData := map[string]interface{}{
+		"query": `
+				mutation CreateRuntime($installationArgs: RuntimeInstallationArgs!) {
+					runtime(installationArgs: $installationArgs) {
+						name
+						newAccessToken
+					}
+				}
+			`,	
+		"variables": map[string]interface{}{
+			"installationArgs": opts,
+		},
+	}
+
+	res := &graphQlRuntimeCreationResponse{}
+	err := r.codefresh.graphqlAPI(ctx, jsonData, res)
+	if err != nil {
+		return nil, fmt.Errorf("failed making a graphql API call while creating runtime: %w", err)
+	}
+
+	if len(res.Errors) > 0 {
+		return nil, graphqlErrorResponse{errors: res.Errors}
+	}
+
+	return &res.Data.Runtime, nil
+}
+
+
+
 func (r *argoRuntime) Get(ctx context.Context, name string) (*model.Runtime, error) {
 	jsonData := map[string]interface{}{
 		"query": `