From e605f3ecf216f1a7dcee097efa9be9e60641907a Mon Sep 17 00:00:00 2001 From: lauk001 Date: Wed, 24 Jan 2024 14:23:54 +0800 Subject: [PATCH] Check for existing cluster ID in configmanager Initial function --- cmd/deploy.go | 7 +++++++ pkg/configmanager/manager.go | 4 +--- 2 files changed, 8 insertions(+), 3 deletions(-) diff --git a/cmd/deploy.go b/cmd/deploy.go index a71367c..2247b34 100755 --- a/cmd/deploy.go +++ b/cmd/deploy.go @@ -57,6 +57,13 @@ func NewDeployCommand() *cobra.Command { func runDeployCmd(cmd *cobra.Command, args []string) error { var clusterID = "cluster" opts.Opts.ClusterID = clusterID + + // Check if clusterConfigFile already exists + clusterConfigFile := filepath.Join(opts.Opts.RootOptDir, opts.Opts.ClusterID, "cluster_config.yaml") + if _, err := os.Stat(clusterConfigFile); err == nil { + return fmt.Errorf("cluster ID: %s is already exists", opts.Opts.ClusterID) + } + if err := configmanager.Initial(&opts.Opts); err != nil { logrus.Errorf("Failed to initialize configuration parameters: %v", err) return err diff --git a/pkg/configmanager/manager.go b/pkg/configmanager/manager.go index e84fbac..6ccabd3 100644 --- a/pkg/configmanager/manager.go +++ b/pkg/configmanager/manager.go @@ -51,9 +51,7 @@ func Initial(opts *opts.OptionsList) error { } if len(files) == 0 { - if len(files) == 0 { - return initializeClusterAsset(&asset.ClusterAsset{}, opts) - } + return initializeClusterAsset(&asset.ClusterAsset{}, opts) } for _, file := range files { -- Gitee