Support runtime environment creation

Author: Oleg Sucharevich

VERSION

@@ -1 +1 @@
-0.0.3
+0.1.0

cmd/create_runtime_environment.go

@@ -0,0 +1,57 @@
+// Copyright © 2018 Codefresh.Inc
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+//     http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+package cmd
+
+import (
+	"fmt"
+
+	"github.com/codefresh-io/go-sdk/pkg/codefresh"
+
+	"github.com/codefresh-io/go-sdk/pkg/utils"
+	"github.com/spf13/cobra"
+	"github.com/spf13/viper"
+)
+
+// createRuntimeEnvironmentCmd represents the createRuntimeEnvironment command
+var createRuntimeEnvironmentCmd = &cobra.Command{
+	Use:     "runtime-environment",
+	Aliases: []string{"re"},
+	Short:   "Create runtime environment",
+
+	Run: func(cmd *cobra.Command, args []string) {
+		client := viper.Get("codefresh")
+		codefreshClient := utils.CastToCodefreshOrDie(client)
+		cluster := cmd.Flag("cluster").Value.String()
+		namespace := cmd.Flag("namespace").Value.String()
+		opt := &codefresh.CreateRuntimeOptions{
+			Cluster:   cluster,
+			Namespace: namespace,
+			HasAgent:  true,
+		}
+		re, err := codefreshClient.CreateRuntimeEnvironment(opt)
+		if err == nil {
+			fmt.Printf("Runtime-Environment %s created\n", re.Name)
+		}
+	},
+}
+
+func init() {
+	createCmd.AddCommand(createRuntimeEnvironmentCmd)
+	createRuntimeEnvironmentCmd.Flags().String("cluster", "", "Set name of the cluster (required)")
+	createRuntimeEnvironmentCmd.MarkFlagRequired("cluster")
+	createRuntimeEnvironmentCmd.Flags().String("namespace", "", "Set name of the namespace (required)")
+	createRuntimeEnvironmentCmd.MarkFlagRequired("namespace")
+	createRuntimeEnvironmentCmd.Flags().Bool("has-agent", false, "Set if the runtime environment is managed by Codefresh agent")
+}

pkg/codefresh/codefresh.go

@@ -13,6 +13,7 @@ type (
 		requestAPI(*requestOptions) (*gentleman.Response, error)
 		ITokenAPI
 		IPipelineAPI
+		IRuntimeEnvironmentAPI
 	}
 )
 

pkg/codefresh/runtime_enrionment.go

@@ -0,0 +1,54 @@
+package codefresh
+
+import "fmt"
+
+type (
+	// IRuntimeEnvironmentAPI declers Codefresh runtime environment API
+	IRuntimeEnvironmentAPI interface {
+		CreateRuntimeEnvironment(*CreateRuntimeOptions) (*RuntimeEnvironment, error)
+	}
+
+	RuntimeEnvironment struct {
+		Name string
+	}
+
+	CreateRuntimeOptions struct {
+		Cluster   string
+		Namespace string
+		HasAgent  bool
+	}
+
+	createRuntimeEnvironmentResponse struct {
+		Name string
+	}
+)
+
+// CreateRuntimeEnvironment - returns pipelines from API
+func (c *codefresh) CreateRuntimeEnvironment(opt *CreateRuntimeOptions) (*RuntimeEnvironment, error) {
+	// r := &createRuntimeEnvironmentResponse{}
+	re := &RuntimeEnvironment{
+		Name: fmt.Sprintf("%s/%s", opt.Cluster, opt.Namespace),
+	}
+	body := map[string]interface{}{
+		"clusterName": opt.Cluster,
+		"namespace":   opt.Namespace,
+	}
+	if opt.HasAgent {
+		body["agent"] = true
+	}
+	resp, err := c.requestAPI(&requestOptions{
+		path:   "/api/custom_clusters/register",
+		method: "POST",
+		body:   body,
+	})
+
+	if err != nil {
+		return nil, err
+	}
+
+	if resp.StatusCode < 400 {
+		return re, nil
+	} else {
+		return nil, fmt.Errorf("Error during runtime environment creation")
+	}
+}