Fix/accounts

cmd/create/environment.go

@@ -1,6 +1,9 @@
 package create
 
 import (
+	"fmt"
+	"strings"
+
 	"github.com/dream11/odin/internal/service"
 	"github.com/dream11/odin/pkg/util"
 	environmentProto "github.com/dream11/odin/proto/gen/go/dream11/od/environment/v1"
@@ -26,6 +29,19 @@ var environmentCmd = &cobra.Command{
 	},
 }
 
+func validateAccounts(accounts string) error {
+	if accounts == "" {
+		return fmt.Errorf("accounts parameter cannot be an empty string")
+	}
+	accountList := strings.Split(accounts, ",")
+	for _, account := range accountList {
+		if account == "" {
+			return fmt.Errorf("accounts parameter contains an empty account")
+		}
+	}
+	return nil
+}
+
 func init() {
 	environmentCmd.Flags().StringVar(&envName, "name", "", "name of the environment to be created")
 	environmentCmd.Flags().StringVar(&accounts, "accounts", "", "list of comma separated cloud provider accounts")
@@ -37,12 +53,19 @@ func init() {
 	if err := environmentCmd.MarkFlagRequired("provisioning-type"); err != nil {
 		log.Fatal("Error marking 'provisioning-type' flag as required:", err)
 	}
+	err = environmentCmd.MarkFlagRequired("accounts")
+	if err != nil {
+		log.Fatal("Error marking 'accounts' flag as required:", err)
+	}
 	createCmd.AddCommand(environmentCmd)
 }
 
 func execute(cmd *cobra.Command) {
 	ctx := cmd.Context()
-
+	// Validate accounts parameter
+	if err := validateAccounts(accounts); err != nil {
+		log.Fatal("Invalid accounts parameter: ", err)
+	}
 	err := environmentClient.CreateEnvironment(&ctx, &environmentProto.CreateEnvironmentRequest{
 		EnvName:          envName,
 		Accounts:         util.SplitProviderAccount(accounts),

cmd/describe/service.go

@@ -3,12 +3,13 @@ package describe
 import (
 	"encoding/json"
 	"fmt"
+	"strconv"
+
 	serviceBackend "github.com/dream11/odin/internal/service"
 	service "github.com/dream11/odin/proto/gen/go/dream11/od/service/v1"
 	"github.com/iancoleman/orderedmap"
 	log "github.com/sirupsen/logrus"
 	"github.com/spf13/cobra"
-	"strconv"
 )
 
 var serviceName string
@@ -58,8 +59,8 @@ func execute(cmd *cobra.Command) {
 	ctx := cmd.Context()
 	response, err := serviceClient.DescribeService(&ctx, &service.DescribeServiceRequest{
 		ServiceName: serviceName,
-		Version: serviceVersion,
-		Params: params,
+		Version:     serviceVersion,
+		Params:      params,
 	})
 
 	if err != nil {
@@ -90,4 +91,3 @@ func writeAsJSON(response *service.DescribeServiceResponse) {
 	}
 	fmt.Println(string(output))
 }
-

cmd/list/service.go

@@ -81,9 +81,9 @@ func writeListServiceAsJSON(response *serviceProto.ListServiceResponse) {
 	var services []map[string]interface{}
 	for _, serviceEntity := range response.Services {
 		services = append(services, map[string]interface{}{
-			"name":        serviceEntity.Name,
-			"version":     serviceEntity.Version,
-			"Tags":      serviceEntity.Tags,
+			"name":    serviceEntity.Name,
+			"version": serviceEntity.Version,
+			"Tags":    serviceEntity.Tags,
 		})
 	}
 	output, _ := json.MarshalIndent(services, "", "  ")

internal/service/service.go

@@ -4,11 +4,12 @@ import (
 	"context"
 	"errors"
 	"fmt"
-	"github.com/dream11/odin/pkg/util"
 	"io"
+	"strings"
 
 	"github.com/briandowns/spinner"
 	"github.com/dream11/odin/pkg/constant"
+	"github.com/dream11/odin/pkg/util"
 	serviceDto "github.com/dream11/odin/proto/gen/go/dream11/od/dto/v1"
 	serviceProto "github.com/dream11/odin/proto/gen/go/dream11/od/service/v1"
 	log "github.com/sirupsen/logrus"
@@ -276,14 +277,20 @@ func (e *Service) ReleaseService(ctx *context.Context, request *serviceProto.Rel
 			message = response.Message
 			message += fmt.Sprintf("\n Service %s %s", response.ServiceStatus.ServiceAction, response.ServiceStatus)
 			for _, compMessage := range response.ComponentsStatus {
-				message += fmt.Sprintf("\n Component %s %s %s", compMessage.ComponentName, compMessage.ComponentAction, compMessage.ComponentStatus)
+				message += fmt.Sprintf("\n Component %s %s %s %s", compMessage.ComponentName, compMessage.ComponentAction, compMessage.ComponentStatus, compMessage.Error)
+				if compMessage.ComponentStatus == "FAILED" {
+					return errors.New(compMessage.Error)
+				}
 			}
+
 			spinnerInstance.Prefix = fmt.Sprintf(" %s  ", message)
 			spinnerInstance.Start()
 		}
 	}
+	if strings.Contains(strings.ToLower(message), "fail") {
+		return errors.New(message)
+	}
 	log.Info("Service released successfully !")
-
 	return err
 }
 

pkg/util/util.go

@@ -2,9 +2,10 @@ package util
 
 import (
 	"fmt"
-	v1 "github.com/dream11/odin/proto/gen/go/dream11/od/service/v1"
 	"net"
 	"strings"
+
+	v1 "github.com/dream11/odin/proto/gen/go/dream11/od/service/v1"
 )
 
 // SplitProviderAccount splits string into list of cloud provider accounts