EVEREST-1815 Replase AlecAivazis/survey lib with charmbracelet/bubbletea

.github/workflows/dev-be-ci.yaml

@@ -245,6 +245,14 @@ jobs:
             ${{ matrix.os }}-go-${{ matrix.go-version }}-build-${{ github.ref }}-
             ${{ matrix.os }}-go-${{ matrix.go-version }}-build-
 
+      # Switch docker data directory to /mnt to have more space for the local Kubernetes cluster
+      - name: Switch docker-daemon data directory to /mnt
+        run: |
+          sudo systemctl stop docker
+          echo '{ "exec-opts": ["native.cgroupdriver=cgroupfs"], "cgroup-parent": "/actions_job", "data-root": "/mnt/docker-data" }' | sudo tee /etc/docker/daemon.json
+          sudo mkdir /mnt/docker-data
+          sudo systemctl start docker
+
       - name: Start local Kubernetes cluster with the local registry
         uses: medyagh/setup-minikube@latest
         id: minikube
@@ -262,6 +270,11 @@ jobs:
         run: |
           CGO_ENABLED=0 GOOS=linux GOARCH=amd64 make build-debug
 
+      - name: Build Everest CLI
+        shell: bash
+        run: |
+          make build-cli
+
       - name: Build Everest docker container
         uses: docker/metadata-action@v5
         id: meta
@@ -319,8 +332,8 @@ jobs:
       - name: Provision Everest using CLI
         shell: bash
         run: |
-          make build-cli
           ./bin/everestctl install -v \
+            --disable-telemetry \
             --version 0.0.0 \
             --version-metadata-url https://check-dev.percona.com \
             --operator.mongodb \
@@ -346,10 +359,14 @@ jobs:
           kubectl patch configmap everest-rbac -n everest-system --patch "$(kubectl get configmap everest-rbac -n everest-system -o json | jq '.data["policy.csv"] += "\ng, everest_ci, role:admin"' | jq '{data: { "policy.csv": .data["policy.csv"] } }')"
           kubectl get configmap everest-rbac -n everest-system -ojsonpath='{.data.policy\.csv}'
 
-      - name: Run integration tests
+      - name: Init integration tests
         run: |
           cd api-tests
           make init
+
+      - name: Run integration tests
+        run: |
+          cd api-tests
           make test
 
       - name: Run debug commands on failure
@@ -360,9 +377,6 @@ jobs:
           kubectl -n everest describe pods
           kubectl -n everest-system logs deploy/everest-server
 
-
-
-
   integration_tests_cli:
     name: CLI Integration Tests
     strategy:
@@ -418,9 +432,9 @@ jobs:
         uses: helm/[email protected]
 
       - name: Run integration tests
-        working-directory: cli-tests
         id: cli-tests
         run: |
+          cd cli-tests
           make init
           make install-operators
           make test-cli

.github/workflows/dev-fe-e2e.yaml

@@ -17,8 +17,8 @@ jobs:
     strategy:
       fail-fast: false
       matrix:
-        go-version: [1.23.x]
-        may-fail: [false]
+        go-version: [ 1.23.x ]
+        may-fail: [ false ]
     runs-on: ubuntu-latest
     steps:
       # Setup Go
@@ -139,6 +139,7 @@ jobs:
         shell: bash
         run: |
           ./bin/everestctl install -v \
+          --disable-telemetry \
           --version 0.0.0 \
           --version-metadata-url https://check-dev.percona.com \
           --skip-wizard \

Makefile

@@ -75,7 +75,7 @@ run-debug: build-debug    ## Run binary
 	bin/everest
 
 run-cli-install: build-cli
-	bin/everestctl install --skip-wizard --namespaces=everest
+	bin/everestctl install --disable-telemetry --skip-wizard --namespaces=everest
 
 cert:                   ## Install dev TLS certificates
 	mkcert -install

cli-tests/Makefile

@@ -4,6 +4,7 @@ init:               ## Install dependencies
 
 install-operators:  ## Install operators to k8s
 	../bin/everestctl install -v \
+		--disable-telemetry \
 		--version 0.0.0 \
 		--version-metadata-url https://check-dev.percona.com \
 		--namespaces percona-everest-operators \

cli-tests/helpers/cliHelper.ts

@@ -73,14 +73,14 @@ export class CliHelper {
   async everestExecSkipWizard(command: string) {
     // eslint-disable-next-line @typescript-eslint/no-unsafe-return
     return test.step(`Run "${command}" command with --skip-wizard`, async () => {
-      return this.execute(`${this.pathToBinary} ${command} --skip-wizard --version 0.0.0 --version-metadata-url https://check-dev.percona.com`);
+      return this.execute(`${this.pathToBinary} ${command} --disable-telemetry --skip-wizard --version 0.0.0 --version-metadata-url https://check-dev.percona.com`);
     });
   }
 
   async everestExecSkipWizardWithEnv(command, env: string) {
     // eslint-disable-next-line @typescript-eslint/no-unsafe-return
     return test.step(`Run "${command}" command with env variables`, async () => {
-      return this.execute(`${env} ${this.pathToBinary} ${command} --skip-wizard --version 0.0.0 --version-metadata-url https://check-dev.percona.com`);
+      return this.execute(`${env} ${this.pathToBinary} ${command} --disable-telemetry --skip-wizard --version 0.0.0 --version-metadata-url https://check-dev.percona.com`);
     });
   }
 

cli-tests/tests/flow/all-operators.spec.ts

@@ -50,13 +50,13 @@ test.describe('Everest CLI install', async () => {
 
       await out.assertSuccess();
       await out.outContainsNormalizedMany([
-        '✓ Installing Everest Helm chart',
-        '✓ Ensuring Everest API deployment is ready',
-        '✓ Ensuring Everest operator deployment is ready',
-        '✓ Ensuring OLM components are ready',
-        '✓ Ensuring Everest CatalogSource is ready',
-        '✓ Ensuring monitoring stack is ready',
-        '✓ Provisioning database namespaces (everest-all)',
+        '✅ Installing Everest Helm chart',
+        '✅ Ensuring Everest API deployment is ready',
+        '✅ Ensuring Everest operator deployment is ready',
+        '✅ Ensuring OLM components are ready',
+        '✅ Ensuring Everest CatalogSource is ready',
+        '✅ Ensuring monitoring stack is ready',
+        '✅ Provisioning database namespace \'everest-all\'',
         'Thank you for installing Everest',
       ]);
     });

cli-tests/tests/flow/mongodb-operator.spec.ts

@@ -54,13 +54,13 @@ test.describe('Everest CLI install', async () => {
 
       await out.assertSuccess();
       await out.outContainsNormalizedMany([
-        '✓ Installing Everest Helm chart',
-        '✓ Ensuring Everest API deployment is ready',
-        '✓ Ensuring Everest operator deployment is ready',
-        '✓ Ensuring OLM components are ready',
-        '✓ Ensuring Everest CatalogSource is ready',
-        '✓ Ensuring monitoring stack is ready',
-        '✓ Provisioning database namespaces (everest-operators)',
+        '✅ Installing Everest Helm chart',
+        '✅ Ensuring Everest API deployment is ready',
+        '✅ Ensuring Everest operator deployment is ready',
+        '✅ Ensuring OLM components are ready',
+        '✅ Ensuring Everest CatalogSource is ready',
+        '✅ Ensuring monitoring stack is ready',
+        '✅ Provisioning database namespace \'everest-operators\'',
         'Thank you for installing Everest',
       ]);
     });

cli-tests/tests/flow/namespaces.spec.ts

@@ -48,12 +48,12 @@ test.describe('Everest CLI install', async () => {
 
       await out.assertSuccess();
       await out.outContainsNormalizedMany([
-        '✓ Installing Everest Helm chart',
-        '✓ Ensuring Everest API deployment is ready',
-        '✓ Ensuring Everest operator deployment is ready',
-        '✓ Ensuring OLM components are ready',
-        '✓ Ensuring Everest CatalogSource is ready',
-        '✓ Ensuring monitoring stack is ready',
+        '✅ Installing Everest Helm chart',
+        '✅ Ensuring Everest API deployment is ready',
+        '✅ Ensuring Everest operator deployment is ready',
+        '✅ Ensuring OLM components are ready',
+        '✅ Ensuring Everest CatalogSource is ready',
+        '✅ Ensuring monitoring stack is ready',
         'Thank you for installing Everest',
       ]);
     });
@@ -65,7 +65,7 @@ test.describe('Everest CLI install', async () => {
         `install`,
       );
       await out.outErrContainsNormalizedMany([
-          '× everest is already installed',
+          '❌ everest is already installed',
       ]);
     });
     await page.waitForTimeout(10_000);
@@ -77,7 +77,7 @@ test.describe('Everest CLI install', async () => {
       );
       await out.assertSuccess();
       await out.outContainsNormalizedMany([
-          '✓ Installing namespace \'everest\'',
+          '✅ Provisioning database namespace \'everest\'',
       ]);
     });
     await page.waitForTimeout(10_000);
@@ -89,7 +89,7 @@ test.describe('Everest CLI install', async () => {
         `add everest --operator.mongodb=false --operator.postgresql=false --operator.xtradb-cluster=true`,
       );
       await out.outErrContainsNormalizedMany([
-          '× invalid namespace (everest): namespace already exists. HINT: set \'--take-ownership\' flag to use existing namespaces',
+        '❌ \'everest\': namespace already exists and is managed by Everest',
       ]);
     });
     await page.waitForTimeout(10_000);
@@ -102,7 +102,7 @@ test.describe('Everest CLI install', async () => {
       );
       await out.assertSuccess();
       await out.outContainsNormalizedMany([
-          '✓ Updating namespace \'everest\'',
+          '✅ Updating database namespace \'everest\'',
       ]);
     });
     await page.waitForTimeout(10_000);
@@ -119,10 +119,10 @@ test.describe('Everest CLI install', async () => {
       );
       await out.assertSuccess();
       await out.outContainsNormalizedMany([
-          '✓ Deleting database clusters in namespace \'everest\'',
-          '✓ Deleting backup storages in namespace \'everest\'',
-          '✓ Deleting monitoring instances in namespace \'everest\'',
-          '✓ Deleting namespace \'everest\'',
+          '✅ Deleting database clusters in namespace \'everest\'',
+          '✅ Deleting backup storages in namespace \'everest\'',
+          '✅ Deleting monitoring instances in namespace \'everest\'',
+          '✅ Deleting database namespace \'everest\'',
       ]);
 
       out = await cli.exec(`kubectl get namespace everest`);
@@ -142,7 +142,7 @@ test.describe('Everest CLI install', async () => {
       );
       await out.assertSuccess();
       await out.outContainsNormalizedMany([
-      '✓ Installing namespace \'existing-ns\'',
+      '✅ Provisioning database namespace \'existing-ns\'',
       ]);
     });
     await page.waitForTimeout(10_000);
@@ -154,10 +154,10 @@ test.describe('Everest CLI install', async () => {
       );
       await out.assertSuccess();
       await out.outContainsNormalizedMany([
-          '✓ Deleting database clusters in namespace \'existing-ns\'',
-          '✓ Deleting backup storages in namespace \'existing-ns\'',
-          '✓ Deleting monitoring instances in namespace \'existing-ns\'',
-          '✓ Deleting resources from namespace \'existing-ns\'',
+          '✅ Deleting database clusters in namespace \'existing-ns\'',
+          '✅ Deleting backup storages in namespace \'existing-ns\'',
+          '✅ Deleting monitoring instances in namespace \'existing-ns\'',
+          '✅ Deleting resources from namespace \'existing-ns\'',
       ]);
 
       out = await cli.exec(`kubectl get namespace existing-ns`);

cli-tests/tests/flow/pg-operator.spec.ts

@@ -51,13 +51,13 @@ test.describe('Everest CLI install', async () => {
 
       await out.assertSuccess();
       await out.outContainsNormalizedMany([
-        '✓ Installing Everest Helm chart',
-        '✓ Ensuring Everest API deployment is ready',
-        '✓ Ensuring Everest operator deployment is ready',
-        '✓ Ensuring OLM components are ready',
-        '✓ Ensuring Everest CatalogSource is ready',
-        '✓ Ensuring monitoring stack is ready',
-        '✓ Provisioning database namespaces (everest-operators)',
+        '✅ Installing Everest Helm chart',
+        '✅ Ensuring Everest API deployment is ready',
+        '✅ Ensuring Everest operator deployment is ready',
+        '✅ Ensuring OLM components are ready',
+        '✅ Ensuring Everest CatalogSource is ready',
+        '✅ Ensuring monitoring stack is ready',
+        '✅ Provisioning database namespace \'everest-operators\'',
         'Thank you for installing Everest',
       ]);
     });

cli-tests/tests/flow/pxc-operator.spec.ts

@@ -54,13 +54,13 @@ test.describe('Everest CLI install', async () => {
 
       await out.assertSuccess();
       await out.outContainsNormalizedMany([
-        '✓ Installing Everest Helm chart',
-        '✓ Ensuring Everest API deployment is ready',
-        '✓ Ensuring Everest operator deployment is ready',
-        '✓ Ensuring OLM components are ready',
-        '✓ Ensuring Everest CatalogSource is ready',
-        '✓ Ensuring monitoring stack is ready',
-        '✓ Provisioning database namespaces (everest-operators)',
+        '✅ Installing Everest Helm chart',
+        '✅ Ensuring Everest API deployment is ready',
+        '✅ Ensuring Everest operator deployment is ready',
+        '✅ Ensuring OLM components are ready',
+        '✅ Ensuring Everest CatalogSource is ready',
+        '✅ Ensuring monitoring stack is ready',
+        '✅ Provisioning database namespace \'everest-operators\'',
         'Thank you for installing Everest',
       ]);
     });

commands/accounts/create.go

@@ -26,6 +26,7 @@ import (
 	accountscli "github.com/percona/everest/pkg/accounts/cli"
 	"github.com/percona/everest/pkg/cli"
 	"github.com/percona/everest/pkg/logger"
+	"github.com/percona/everest/pkg/output"
 )
 
 var (
@@ -53,17 +54,51 @@ func accountsCreatePreRun(cmd *cobra.Command, _ []string) { //nolint:revive
 	// Copy global flags to config
 	accountsCreateCfg.Pretty = !(cmd.Flag(cli.FlagVerbose).Changed || cmd.Flag(cli.FlagJSON).Changed)
 	accountsCreateCfg.KubeconfigPath = cmd.Flag(cli.FlagKubeconfig).Value.String()
+
+	// Check username
+	if accountsCreateOpts.Username != "" {
+		// Validate provided username for new account.
+		if err := accountscli.ValidateUsername(accountsCreateOpts.Username); err != nil {
+			output.PrintError(err, logger.GetLogger(), accountsCreateCfg.Pretty)
+			os.Exit(1)
+		}
+	} else {
+		// Ask user in interactive mode to provide username for new account.
+		if username, err := accountscli.PopulateUsername(cmd.Context()); err != nil {
+			output.PrintError(err, logger.GetLogger(), accountsCreateCfg.Pretty)
+			os.Exit(1)
+		} else {
+			accountsCreateOpts.Username = username
+		}
+	}
+
+	// Check password
+	if accountsCreateOpts.Password != "" {
+		// Validate provided password for new account.
+		if err := accountscli.ValidatePassword(accountsCreateOpts.Password); err != nil {
+			output.PrintError(err, logger.GetLogger(), accountsCreateCfg.Pretty)
+			os.Exit(1)
+		}
+	} else {
+		// Ask user in interactive mode to provide password for new account.
+		if password, err := accountscli.PopulatePassword(cmd.Context()); err != nil {
+			output.PrintError(err, logger.GetLogger(), accountsCreateCfg.Pretty)
+			os.Exit(1)
+		} else {
+			accountsCreateOpts.Password = password
+		}
+	}
 }
 
 func accountsCreateRun(cmd *cobra.Command, _ []string) { //nolint:revive
 	cliA, err := accountscli.NewAccounts(*accountsCreateCfg, logger.GetLogger())
 	if err != nil {
-		logger.GetLogger().Error(err)
+		output.PrintError(err, logger.GetLogger(), accountsCreateCfg.Pretty)
 		os.Exit(1)
 	}
 
 	if err := cliA.Create(cmd.Context(), *accountsCreateOpts); err != nil {
-		logger.GetLogger().Error(err)
+		output.PrintError(err, logger.GetLogger(), accountsCreateCfg.Pretty)
 		os.Exit(1)
 	}
 }