feat: cd install check cluster

cmd/plural/cd.go

@@ -62,9 +62,9 @@ func (p *Plural) cdCommands() []cli.Command {
 			},
 		},
 		{
-			Name:   "eject",
-			Action: p.handleEject,
-			Usage:  "ejects cluster scaffolds",
+			Name:      "eject",
+			Action:    p.handleEject,
+			Usage:     "ejects cluster scaffolds",
 			ArgsUsage: "<cluster-id>",
 			// TODO: enable once logic is finished
 			Hidden: true,
@@ -93,6 +93,17 @@ func (p *Plural) doInstallOperator(url, token string) error {
 	if err != nil && !apierrors.IsAlreadyExists(err) {
 		return err
 	}
+	consoleClient, err := console.NewConsoleClient(token, url)
+	if err != nil {
+		return err
+	}
+	myCluster, err := consoleClient.MyCluster()
+	if err != nil {
+		return err
+	}
+	if !confirm(fmt.Sprintf("Are you sure you want to install deploy operator for %s cluster?", myCluster.MyCluster.Name), "PLURAL_INSTALL_AGENT_CONFIRM") {
+		return nil
+	}
 	err = console.InstallAgent(url, token, operatorNamespace)
 	if err == nil {
 		utils.Success("deployment operator installed successfully\n")

pkg/console/clusters.go

@@ -58,3 +58,7 @@ func (c *consoleClient) CreateCluster(attributes consoleclient.ClusterAttributes
 	}
 	return newCluster, nil
 }
+
+func (c *consoleClient) MyCluster() (*consoleclient.MyCluster, error) {
+	return c.client.MyCluster(c.ctx)
+}

pkg/console/console.go

@@ -37,6 +37,7 @@ type ConsoleClient interface {
 	SavePipeline(name string, attrs consoleclient.PipelineAttributes) (*consoleclient.PipelineFragment, error)
 	CreateCluster(attributes consoleclient.ClusterAttributes) (*consoleclient.CreateCluster, error)
 	CreateProvider(attr consoleclient.ClusterProviderAttributes) (*consoleclient.CreateClusterProvider, error)
+	MyCluster() (*consoleclient.MyCluster, error)
 }
 
 func NewConsoleClient(token, url string) (ConsoleClient, error) {