mirror of
https://github.com/edgelesssys/constellation.git
synced 2024-12-13 18:04:20 -05:00
8e4feb7e2a
* add Azure Terraform module * add maa-patching command to cli * refactor release process * factor out image fetching to own action * add CI * generate * fix some unnecessary changes Signed-off-by: Moritz Sanft <58110325+msanft@users.noreply.github.com> * use `constellation maa-patch` in ci * insecure flag when using debug image Signed-off-by: Moritz Sanft <58110325+msanft@users.noreply.github.com> * only update maa url if existing Signed-off-by: Moritz Sanft <58110325+msanft@users.noreply.github.com> * make node group zone optional on aws and gcp Signed-off-by: Moritz Sanft <58110325+msanft@users.noreply.github.com> * [remove] register updated workflow Signed-off-by: Moritz Sanft <58110325+msanft@users.noreply.github.com> * Revert "[remove] register updated workflow" This reverts commit e70b9515b7eabbcbe0d41fa1296c48750cd02ace. * create MAA Signed-off-by: Moritz Sanft <58110325+msanft@users.noreply.github.com> * make maa-patching only run on azure Signed-off-by: Moritz Sanft <58110325+msanft@users.noreply.github.com> * add comment Signed-off-by: Moritz Sanft <58110325+msanft@users.noreply.github.com> * require node group zone for GCP and AWS * remove unnecessary bazel action * stamp version to correct file * refer to `maa-patch` command in docs * run Azure test in weekly e2e * comment / naming improvements * remove sa_account resource * disable spellcheck ot use "URL" * `create_maa` variable * don't write maa url to config Signed-off-by: Moritz Sanft <58110325+msanft@users.noreply.github.com> * default to nightly image * use input ref and stream * fix command check * don't set region in weekly e2e call * patch maa if url is not empty Signed-off-by: Moritz Sanft <58110325+msanft@users.noreply.github.com> * remove `create_maa` variable * remove binaries Signed-off-by: Moritz Sanft <58110325+msanft@users.noreply.github.com> * remove undefined input * replace invalid attestation URL error message Co-authored-by: Thomas Tendyck <51411342+thomasten@users.noreply.github.com> * fix punctuation Co-authored-by: Thomas Tendyck <51411342+thomasten@users.noreply.github.com> * skip hidden commands in clidocgen Signed-off-by: Moritz Sanft <58110325+msanft@users.noreply.github.com> * enable spellcheck before code block * move spellcheck trigger out of info block Signed-off-by: Moritz Sanft <58110325+msanft@users.noreply.github.com> * fix workflow dependencies * let image default to CLI version --------- Signed-off-by: Moritz Sanft <58110325+msanft@users.noreply.github.com> Co-authored-by: Thomas Tendyck <51411342+thomasten@users.noreply.github.com>
119 lines
3.1 KiB
Go
119 lines
3.1 KiB
Go
/*
|
|
Copyright (c) Edgeless Systems GmbH
|
|
|
|
SPDX-License-Identifier: AGPL-3.0-only
|
|
*/
|
|
|
|
/*
|
|
Package cmd is the entrypoint of the Constellation CLI.
|
|
|
|
Business logic of the CLI shall be implemented in the internal/cmd package.
|
|
*/
|
|
package cmd
|
|
|
|
import (
|
|
"context"
|
|
"fmt"
|
|
"os"
|
|
"os/signal"
|
|
|
|
"github.com/edgelesssys/constellation/v2/cli/internal/cmd"
|
|
"github.com/spf13/cobra"
|
|
)
|
|
|
|
// Execute starts the CLI.
|
|
func Execute() error {
|
|
cobra.EnableCommandSorting = false
|
|
rootCmd := NewRootCmd()
|
|
ctx, cancel := signalContext(context.Background(), os.Interrupt)
|
|
defer cancel()
|
|
return rootCmd.ExecuteContext(ctx)
|
|
}
|
|
|
|
// NewRootCmd creates the root command.
|
|
func NewRootCmd() *cobra.Command {
|
|
rootCmd := &cobra.Command{
|
|
Use: "constellation",
|
|
Short: "Manage your Constellation cluster",
|
|
Long: "Manage your Constellation cluster.",
|
|
PersistentPreRunE: preRunRoot,
|
|
}
|
|
|
|
// Set output of cmd.Print to stdout. (By default, it's stderr.)
|
|
rootCmd.SetOut(os.Stdout)
|
|
|
|
rootCmd.PersistentFlags().StringP("workspace", "C", "", "path to the Constellation workspace")
|
|
rootCmd.PersistentFlags().Bool("debug", false, "enable debug logging")
|
|
rootCmd.PersistentFlags().Bool("force", false, "disable version compatibility checks - might result in corrupted clusters")
|
|
rootCmd.PersistentFlags().String("tf-log", "NONE", "Terraform log level")
|
|
|
|
must(rootCmd.MarkPersistentFlagDirname("workspace"))
|
|
|
|
rootCmd.AddCommand(cmd.NewConfigCmd())
|
|
rootCmd.AddCommand(cmd.NewCreateCmd())
|
|
rootCmd.AddCommand(cmd.NewApplyCmd())
|
|
rootCmd.AddCommand(cmd.NewMiniCmd())
|
|
rootCmd.AddCommand(cmd.NewStatusCmd())
|
|
rootCmd.AddCommand(cmd.NewVerifyCmd())
|
|
rootCmd.AddCommand(cmd.NewUpgradeCmd())
|
|
rootCmd.AddCommand(cmd.NewRecoverCmd())
|
|
rootCmd.AddCommand(cmd.NewTerminateCmd())
|
|
rootCmd.AddCommand(cmd.NewIAMCmd())
|
|
rootCmd.AddCommand(cmd.NewVersionCmd())
|
|
rootCmd.AddCommand(cmd.NewInitCmd())
|
|
rootCmd.AddCommand(cmd.NewMaaPatchCmd())
|
|
|
|
return rootCmd
|
|
}
|
|
|
|
// signalContext returns a context that is canceled on the handed signal.
|
|
// The signal isn't watched after its first occurrence. Call the cancel
|
|
// function to ensure the internal goroutine is stopped and the signal isn't
|
|
// watched any longer.
|
|
func signalContext(ctx context.Context, sig os.Signal) (context.Context, context.CancelFunc) {
|
|
sigCtx, stop := signal.NotifyContext(ctx, sig)
|
|
done := make(chan struct{}, 1)
|
|
stopDone := make(chan struct{}, 1)
|
|
|
|
go func() {
|
|
defer func() { stopDone <- struct{}{} }()
|
|
defer stop()
|
|
select {
|
|
case <-sigCtx.Done():
|
|
fmt.Println(" Signal caught. Press ctrl+c again to terminate the program immediately.")
|
|
case <-done:
|
|
}
|
|
}()
|
|
|
|
cancelFunc := func() {
|
|
done <- struct{}{}
|
|
<-stopDone
|
|
}
|
|
|
|
return sigCtx, cancelFunc
|
|
}
|
|
|
|
func preRunRoot(cmd *cobra.Command, _ []string) error {
|
|
cmd.SilenceUsage = true
|
|
|
|
workspace, err := cmd.Flags().GetString("workspace")
|
|
if err != nil {
|
|
return fmt.Errorf("getting workspace flag: %w", err)
|
|
}
|
|
|
|
// Change to workspace directory if set.
|
|
if workspace != "" {
|
|
if err := os.Chdir(workspace); err != nil {
|
|
return fmt.Errorf("changing from current directory to workspace %q: %w", workspace, err)
|
|
}
|
|
}
|
|
|
|
return nil
|
|
}
|
|
|
|
func must(err error) {
|
|
if err != nil {
|
|
panic(err)
|
|
}
|
|
}
|