root.go

package cmd

import (
	"bytes"
	"context"
	"errors"
	"fmt"
	"io"
	"math"
	"os"
	"os/signal"
	"path/filepath"
	"strings"
	"syscall"

	"github.com/charmbracelet/lipgloss"
	xterm "github.com/charmbracelet/x/term"
	"github.com/elewis787/boa"
	"github.com/muesli/reflow/wordwrap"
	"github.com/muesli/termenv"
	"github.com/spf13/cobra"
	"github.com/spf13/pflag"
	"github.com/spf13/viper"

	errUtils "github.com/cloudposse/atmos/errors"
	e "github.com/cloudposse/atmos/internal/exec"
	"github.com/cloudposse/atmos/internal/tui/templates"
	"github.com/cloudposse/atmos/internal/tui/templates/term"
	atmosansi "github.com/cloudposse/atmos/pkg/ansi"
	cfg "github.com/cloudposse/atmos/pkg/config"
	// Import adapters to register them with the config package.
	_ "github.com/cloudposse/atmos/pkg/config/adapters"

	// Import component providers to register them with the component registry.
	// The init() function in each package registers the provider.
	_ "github.com/cloudposse/atmos/pkg/component/ansible"
	_ "github.com/cloudposse/atmos/pkg/component/mock"

	"github.com/cloudposse/atmos/pkg/data"
	"github.com/cloudposse/atmos/pkg/filesystem"
	"github.com/cloudposse/atmos/pkg/flags"
	"github.com/cloudposse/atmos/pkg/flags/compat"
	iolib "github.com/cloudposse/atmos/pkg/io"
	log "github.com/cloudposse/atmos/pkg/logger"
	"github.com/cloudposse/atmos/pkg/pager"
	"github.com/cloudposse/atmos/pkg/perf"
	"github.com/cloudposse/atmos/pkg/profiler"
	"github.com/cloudposse/atmos/pkg/schema"
	"github.com/cloudposse/atmos/pkg/telemetry"
	"github.com/cloudposse/atmos/pkg/terminal"
	"github.com/cloudposse/atmos/pkg/ui"
	"github.com/cloudposse/atmos/pkg/ui/heatmap"
	"github.com/cloudposse/atmos/pkg/ui/markdown"
	"github.com/cloudposse/atmos/pkg/ui/theme"
	"github.com/cloudposse/atmos/pkg/utils"
	pkgversion "github.com/cloudposse/atmos/pkg/version"

	// Import built-in command packages for side-effect registration.
	// The init() function in each package registers the command with the registry.
	_ "github.com/cloudposse/atmos/cmd/about"
	_ "github.com/cloudposse/atmos/cmd/ansible"
	_ "github.com/cloudposse/atmos/cmd/aws"
	"github.com/cloudposse/atmos/cmd/devcontainer"
	_ "github.com/cloudposse/atmos/cmd/env"
	_ "github.com/cloudposse/atmos/cmd/helmfile"
	"github.com/cloudposse/atmos/cmd/internal"
	_ "github.com/cloudposse/atmos/cmd/list"
	_ "github.com/cloudposse/atmos/cmd/profile"
	_ "github.com/cloudposse/atmos/cmd/terraform"
	"github.com/cloudposse/atmos/cmd/terraform/backend"
	"github.com/cloudposse/atmos/cmd/terraform/workdir"
	themeCmd "github.com/cloudposse/atmos/cmd/theme"
	toolchainCmd "github.com/cloudposse/atmos/cmd/toolchain"
	_ "github.com/cloudposse/atmos/cmd/vendor"
	"github.com/cloudposse/atmos/cmd/version"
	_ "github.com/cloudposse/atmos/cmd/workflow"
	"github.com/cloudposse/atmos/pkg/toolchain"
)

const (
	// LogFileMode is the file mode for log files.
	logFileMode = 0o644
	// DefaultTopFunctionsMax is the default number of top functions to display in performance summary.
	defaultTopFunctionsMax = 50
	// VerboseFlagName is the name of the verbose flag.
	verboseFlagName = "verbose"
	// AnsiEscapePrefix is the ANSI escape sequence prefix.
	ansiEscapePrefix = "\x1b["
)

// atmosConfig This is initialized before everything in the Execute function. So we can directly use this.
var atmosConfig schema.AtmosConfiguration

// profilerServer holds the global profiler server instance.
var profilerServer *profiler.Server

// logFileHandle holds the opened log file for the lifetime of the program.
var logFileHandle *os.File

// chdirProcessed tracks whether chdir has already been processed to avoid double-processing.
var chdirProcessed bool

// parseChdirFromArgs manually parses --chdir or -C flag from os.Args.
// This is needed for commands with DisableFlagParsing=true (terraform, helmfile, packer)
// parseChdirFromArgs scans the process arguments for a chdir flag and returns the specified path if present.
// It recognizes `--chdir=value`, `--chdir value`, `-C=value`, `-Cvalue`, and `-C value` forms.
// If no chdir flag is found, it returns an empty string.
func parseChdirFromArgs() string {
	return parseChdirFromArgsInternal(os.Args)
}

// parseUseVersionFromArgs manually parses --use-version flag from os.Args.
// This is needed for commands with DisableFlagParsing=true (terraform, helmfile, packer)
// where Cobra doesn't parse flags automatically.
// It recognizes `--use-version=value` and `--use-version value` forms.
// If no --use-version flag is found, it returns an empty string.
func parseUseVersionFromArgs() string {
	return parseUseVersionFromArgsInternal(os.Args)
}

// parseUseVersionFromArgsInternal manually parses --use-version flag from the provided args.
// This internal version accepts args as a parameter for testability.
func parseUseVersionFromArgsInternal(args []string) string {
	for i := 0; i < len(args); i++ {
		arg := args[i]

		// Stop scanning after bare "--" (end-of-flags delimiter).
		if arg == "--" {
			break
		}

		// Check for --use-version=value format.
		if strings.HasPrefix(arg, "--use-version=") {
			return strings.TrimPrefix(arg, "--use-version=")
		}

		// Check for --use-version value format (next arg is the value).
		if arg == "--use-version" {
			if i+1 < len(args) {
				return args[i+1]
			}
		}
	}
	return ""
}

// parseChdirFromArgsInternal manually parses --chdir or -C flag from the provided args.
// This internal version accepts args as a parameter for testability.
func parseChdirFromArgsInternal(args []string) string {
	for i := 0; i < len(args); i++ {
		arg := args[i]

		// Stop scanning after bare "--" (end-of-flags delimiter).
		if arg == "--" {
			break
		}

		// Check for --chdir=value format.
		if strings.HasPrefix(arg, "--chdir=") {
			return strings.TrimPrefix(arg, "--chdir=")
		}

		// Check for -C=value format.
		if strings.HasPrefix(arg, "-C=") {
			return strings.TrimPrefix(arg, "-C=")
		}

		// Check for -C<value> format (concatenated, e.g., -C../foo).
		if strings.HasPrefix(arg, "-C") && len(arg) > 2 {
			return arg[2:]
		}

		// Check for --chdir value or -C value format (next arg is the value).
		if arg == "--chdir" || arg == "-C" {
			if i+1 < len(args) {
				return args[i+1]
			}
		}
	}
	return ""
}

// processEarlyChdirFlag processes --chdir flag before RootCmd is fully initialized.
// This is called in Execute() before loading atmos.yaml to ensure the config is loaded
// processEarlyChdirFlag changes the current working directory based on the first
// occurrence of the `--chdir`/`-C` flag (parsed from os.Args) or the ATMOS_CHDIR
// environment variable, expanding `~`, resolving to an absolute path, and
// validating that the target exists and is a directory.
// It returns nil on success or an error describing why the directory could not
// be resolved or changed.
func processEarlyChdirFlag() error {
	// If chdir already processed, skip (avoid double-processing).
	if chdirProcessed {
		return nil
	}

	// Parse --chdir from os.Args since we can't use Cobra flags yet.
	chdir := parseChdirFromArgs()

	// If flag is not set, check environment variable.
	if chdir == "" {
		//nolint:forbidigo // Must use os.Getenv: chdir is processed before Viper configuration loads.
		chdir = os.Getenv("ATMOS_CHDIR")
	}

	if chdir == "" {
		return nil // No chdir specified.
	}

	// Expand tilde to home directory using filesystem package.
	homeDirProvider := filesystem.NewOSHomeDirProvider()
	expandedPath, err := homeDirProvider.Expand(chdir)
	if err != nil {
		return fmt.Errorf("%w: %w", errUtils.ErrPathResolution, err)
	}

	// Clean and make absolute to handle both relative and absolute paths.
	absPath, err := filepath.Abs(expandedPath)
	if err != nil {
		return fmt.Errorf("%w: invalid chdir path: %s", errUtils.ErrPathResolution, chdir)
	}

	// Verify the directory exists before attempting to change to it.
	stat, err := os.Stat(absPath)
	if err != nil {
		if os.IsNotExist(err) {
			return fmt.Errorf("%w: directory does not exist: %s", errUtils.ErrWorkdirNotExist, absPath)
		}
		return fmt.Errorf("%w: failed to access directory: %s", errUtils.ErrStatFile, absPath)
	}

	if !stat.IsDir() {
		return fmt.Errorf("%w: not a directory: %s", errUtils.ErrWorkdirNotExist, absPath)
	}

	// Change to the specified directory.
	if err := os.Chdir(absPath); err != nil {
		return fmt.Errorf("%w: failed to change directory to %s", errUtils.ErrPathResolution, absPath)
	}

	// Mark as processed to avoid double-processing in PersistentPreRun.
	chdirProcessed = true

	return nil
}

// syncGlobalFlagsToViper synchronizes global flags from Cobra's FlagSet to Viper.
// This is necessary because Viper's BindPFlag doesn't immediately sync values when flags are parsed.
// Call this after Cobra parses flags but before accessing flag values via Viper.
//
// Background: When using viper.BindPFlag(), the binding happens at initialization time,
// but the actual flag value isn't synced to Viper until you call viper.Get*().
// For some code paths (especially in InitCliConfig), we need the flag values
// available in Viper before config loading completes.
//
// This function explicitly syncs changed flags to Viper, making their values
// immediately available via viper.Get*() calls.
func syncGlobalFlagsToViper(cmd *cobra.Command) {
	v := viper.GetViper()

	// Sync profile flag if explicitly set.
	if cmd.Flags().Changed("profile") {
		if profiles, err := cmd.Flags().GetStringSlice("profile"); err == nil {
			v.Set("profile", profiles)
		}
	}

	// Sync identity flag if explicitly set.
	if cmd.Flags().Changed("identity") {
		if identity, err := cmd.Flags().GetString("identity"); err == nil {
			v.Set("identity", identity)
		}
	}
}

// processChdirFlag processes the --chdir flag and ATMOS_CHDIR environment variable,
// changing the working directory before any other operations.
// Precedence: --chdir flag > ATMOS_CHDIR environment variable.
// Note: This is also called from PersistentPreRun, but will be a no-op if
// processChdirFlag changes the current working directory when a chdir target is provided
// via the --chdir flag (or by parsing os.Args when flag parsing is disabled) or the
// ATMOS_CHDIR environment variable, and marks the change as processed to avoid
// double-processing.
//
// It expands a leading tilde, resolves the path to an absolute location, verifies the
// path exists and is a directory, then calls os.Chdir. If the chdir has already been
// handled, the function returns immediately. It returns an error when the path cannot
// be resolved, does not exist, is not a directory, or when changing directories fails.
func processChdirFlag(cmd *cobra.Command) error {
	// If chdir already processed in Execute(), skip to avoid double-processing.
	if chdirProcessed {
		return nil
	}

	// Try to get chdir from parsed flags first (works when DisableFlagParsing=false).
	chdir, _ := cmd.Flags().GetString("chdir")

	// If flag parsing is disabled (terraform/helmfile/packer commands), manually parse os.Args.
	// This is necessary because Cobra doesn't parse flags when DisableFlagParsing=true,
	// but PersistentPreRun runs before the command's Run function where flags would be manually parsed.
	if chdir == "" {
		chdir = parseChdirFromArgs()
	}
	// If flag is not set, check environment variable.
	// Note: chdir is not supported in atmos.yaml since it must be processed before atmos.yaml is loaded.
	if chdir == "" {
		//nolint:forbidigo // Must use os.Getenv: chdir is processed before Viper configuration loads.
		chdir = os.Getenv("ATMOS_CHDIR")
	}

	if chdir == "" {
		return nil // No chdir specified.
	}

	// Expand tilde to home directory using filesystem package.
	homeDirProvider := filesystem.NewOSHomeDirProvider()
	expandedPath, err := homeDirProvider.Expand(chdir)
	if err != nil {
		return fmt.Errorf("%w: %w", errUtils.ErrPathResolution, err)
	}

	// Clean and make absolute to handle both relative and absolute paths.
	absPath, err := filepath.Abs(expandedPath)
	if err != nil {
		return fmt.Errorf("%w: invalid chdir path: %s", errUtils.ErrPathResolution, chdir)
	}

	// Verify the directory exists before attempting to change to it.
	stat, err := os.Stat(absPath)
	if err != nil {
		if os.IsNotExist(err) {
			return fmt.Errorf("%w: directory does not exist: %s", errUtils.ErrWorkdirNotExist, absPath)
		}
		return fmt.Errorf("%w: failed to access directory: %s", errUtils.ErrStatFile, absPath)
	}

	if !stat.IsDir() {
		return fmt.Errorf("%w: not a directory: %s", errUtils.ErrWorkdirNotExist, absPath)
	}

	// Change to the specified directory.
	if err := os.Chdir(absPath); err != nil {
		return fmt.Errorf("%w: failed to change directory to %s", errUtils.ErrPathResolution, absPath)
	}

	// Mark as processed to avoid double-processing.
	chdirProcessed = true

	return nil
}

// RootCmd represents the base command when called without any subcommands.
var RootCmd = &cobra.Command{
	Use:   "atmos",
	Short: "Framework for Infrastructure Orchestration",
	Long:  `Atmos is a framework for orchestrating and operating infrastructure workflows across multiple cloud and DevOps toolchains.`,
	// Note: FParseErrWhitelist is NOT set on RootCmd to allow proper flag validation.
	// Individual commands that need to pass through flags (terraform, helmfile, packer)
	// set FParseErrWhitelist{UnknownFlags: true} explicitly.
	PersistentPreRun: func(cmd *cobra.Command, args []string) {
		// Set verbose flag for error formatting before any command execution or fatal exits.
		if cmd.Flags().Changed(verboseFlagName) {
			// CLI flag explicitly set - use it.
			verbose, flagErr := cmd.Flags().GetBool(verboseFlagName)
			if flagErr != nil {
				errUtils.CheckErrorPrintAndExit(flagErr, "", "")
			}
			errUtils.SetVerboseFlag(verbose)
		} else if viper.IsSet(verboseFlagName) {
			// CLI flag not set - check environment variable via Viper.
			verbose := viper.GetBool(verboseFlagName)
			errUtils.SetVerboseFlag(verbose)
		}

		// Check for conflicting flags: --version and --use-version cannot be used together.
		if cmd.Flags().Changed("version") && cmd.Flags().Changed("use-version") {
			conflictErr := errUtils.Build(errUtils.ErrInvalidFlag).
				WithExplanation("--version and --use-version cannot be used together").
				WithHint("Use --version to display the current Atmos version").
				WithHint("Use --use-version to run a command with a specific Atmos version").
				Err()
			errUtils.CheckErrorPrintAndExit(conflictErr, "", "")
		}

		// Determine if the command is a help command or if the help flag is set.
		isHelpCommand := cmd.Name() == "help"
		helpFlag := cmd.Flags().Changed("help")

		isHelpRequested := isHelpCommand || helpFlag

		if isHelpRequested {
			// Do not silence usage or errors when help is invoked.
			cmd.SilenceUsage = false
			cmd.SilenceErrors = false
		} else {
			cmd.SilenceUsage = true
			cmd.SilenceErrors = true
		}

		// Process --chdir flag before any other operations (including config loading).
		if err := processChdirFlag(cmd); err != nil {
			errUtils.CheckErrorPrintAndExit(err, "", "")
		}

		// Configure lipgloss color profile early, before config loading.
		// This is critical because stack processing during config load may trigger
		// validation that uses theme styles. We need to set the color profile BEFORE
		// those styles are accessed to ensure NO_COLOR and other settings are respected.
		configureEarlyColorProfile(cmd)

		// Sync global flags from Cobra to Viper before InitCliConfig.
		// This ensures flag values are immediately available in Viper for config loading.
		syncGlobalFlagsToViper(cmd)

		configAndStacksInfo := schema.ConfigAndStacksInfo{}
		// Honor CLI overrides for resolving atmos.yaml and its imports.
		if bp, _ := cmd.Flags().GetString("base-path"); bp != "" {
			configAndStacksInfo.AtmosBasePath = bp
		}
		if cfgFiles, _ := cmd.Flags().GetStringSlice("config"); len(cfgFiles) > 0 {
			configAndStacksInfo.AtmosConfigFilesFromArg = cfgFiles
		}
		if cfgDirs, _ := cmd.Flags().GetStringSlice("config-path"); len(cfgDirs) > 0 {
			configAndStacksInfo.AtmosConfigDirsFromArg = cfgDirs
		}
		// Load the config (includes env var bindings); don't store globally yet.
		tmpConfig, err := cfg.InitCliConfig(configAndStacksInfo, false)
		if err != nil {
			if errors.Is(err, cfg.NotFound) {
				// For help commands or when help flag is set, we don't want to show the error.
				if !isHelpRequested {
					log.Warn(err.Error())
				}
			} else if isVersionCommand() {
				// Version command should always work, even with invalid config.
				// Log config error but allow version command to proceed.
				log.Debug("CLI configuration error (continuing for version command)", "error", err)
			} else {
				// Enrich config errors with helpful context.
				enrichedErr := errUtils.Build(err).
					WithHint("Verify your atmos.yaml syntax and configuration").
					WithHint("Run 'atmos version' to check if Atmos is working").
					WithExitCode(2). // Config/usage error
					Err()
				errUtils.CheckErrorPrintAndExit(enrichedErr, "", "")
			}
		}

		// Check for version.use configuration and re-exec with specified version if needed.
		// This runs after profiles are loaded, so version.use can be set via profiles.
		if !isHelpRequested && err == nil {
			// Check if explicit --use-version flag was provided.
			var explicitVersionRequested bool
			var explicitVersion string

			// First try Cobra's parsed flag (works when DisableFlagParsing=false).
			if cmd.Flags().Changed("use-version") {
				if useVersion, flagErr := cmd.Flags().GetString("use-version"); flagErr == nil && useVersion != "" {
					explicitVersion = useVersion
					explicitVersionRequested = true
				}
			}

			// For commands with DisableFlagParsing=true (terraform, helmfile, packer),
			// manually parse --use-version from os.Args.
			if !explicitVersionRequested {
				if useVersion := parseUseVersionFromArgs(); useVersion != "" {
					explicitVersion = useVersion
					explicitVersionRequested = true
				}
			}

			// Set ATMOS_VERSION_USE env var if explicit flag was provided.
			if explicitVersionRequested {
				_ = os.Setenv(pkgversion.VersionUseEnvVar, explicitVersion)
			}

			// Skip re-exec for version management commands (to avoid loops),
			// unless an explicit --use-version flag was provided.
			shouldReexec := explicitVersionRequested || !isVersionManagementCommand(cmd)
			if shouldReexec {
				// CheckAndReexec returns true only on successful syscall.Exec, which replaces
				// the current process entirely. This means true is never returned in practice
				// since exec doesn't return. We call it for its side effects.
				_ = pkgversion.CheckAndReexec(&tmpConfig)
			}
		}

		// Setup profiler before command execution (but skip for help commands).
		if !isHelpRequested {
			if setupErr := setupProfiler(cmd, &tmpConfig); setupErr != nil {
				errUtils.CheckErrorPrintAndExit(setupErr, "Failed to setup profiler", "")
			}
		}

		// Note: --version flag is now handled in main.go before Execute() for production use.
		// For tests that use RootCmd.SetArgs(["--version"]), we don't need special handling here
		// since tests expect normal command flow without os.Exit.

		// Enable performance tracking if heatmap flag is set.
		// P95 latency tracking via HDR histogram is automatically enabled.
		if showHeatmap, _ := cmd.Flags().GetBool("heatmap"); showHeatmap {
			perf.EnableTracking(true)
		}

		// Print telemetry disclosure if needed (skip for completion commands and when CLI config not found).
		if !isCompletionCommand(cmd) && err == nil {
			telemetry.PrintTelemetryDisclosure()
		}

		// Initialize I/O context and global formatter after flag parsing.
		// This ensures flags like --no-color, --redirect-stderr, --mask are respected.
		// Initialize() sets the global iolib.Data and iolib.UI writers with masking enabled.
		if ioErr := iolib.Initialize(); ioErr != nil {
			errUtils.CheckErrorPrintAndExit(fmt.Errorf("failed to initialize I/O context: %w", ioErr), "", "")
		}
		ioCtx := iolib.GetContext()
		ui.InitFormatter(ioCtx)
		data.InitWriter(ioCtx)
		data.SetMarkdownRenderer(ui.Format) // Connect markdown rendering to data channel

		// Check if running an experimental command.
		// This happens after I/O init so ui.Experimental() can output properly.
		// Walk up the command tree to find if any parent is experimental.
		// For example, "atmos devcontainer list" should trigger the devcontainer warning.
		experimentalCmd := findExperimentalParent(cmd)
		if experimentalCmd != "" {
			experimentalMode := tmpConfig.Settings.Experimental
			if experimentalMode == "" {
				experimentalMode = "warn" // Default
			}

			switch experimentalMode {
			case "silence":
				// Do nothing - completely silent.
			case "disable":
				// Command is registered but disabled at runtime.
				errUtils.CheckErrorPrintAndExit(
					errUtils.Build(errUtils.ErrExperimentalDisabled).
						WithContext("command", experimentalCmd).
						WithHint("Enable with settings.experimental: warn").
						Err(),
					"", "",
				)
			case "warn":
				ui.Experimental(experimentalCmd)
			case "error":
				ui.Experimental(experimentalCmd)
				errUtils.CheckErrorPrintAndExit(
					errUtils.Build(errUtils.ErrExperimentalRequiresIn).
						WithContext("command", experimentalCmd).
						WithHint("Enable with settings.experimental: warn").
						Err(),
					"", "",
				)
			}
		}

		// Check for experimental settings (non-command features gated by config values).
		// This extends the experimental check above to cover settings like key_delimiter.
		checkExperimentalSettings(&tmpConfig)

		// Configure lipgloss color profile based on terminal capabilities.
		// This ensures tables and styled output degrade gracefully when piped or in non-TTY environments.
		term := terminal.New()
		lipgloss.SetColorProfile(convertToTermenvProfile(term.ColorProfile()))
	},
	PersistentPostRun: func(cmd *cobra.Command, args []string) {
		// Stop profiler after command execution.
		if profilerServer != nil {
			if stopErr := profilerServer.Stop(); stopErr != nil {
				log.Error("Failed to stop profiler", "error", stopErr)
			}
		}

		// Show performance heatmap if enabled.
		showHeatmap, _ := cmd.Flags().GetBool("heatmap")
		if showHeatmap {
			heatmapMode, _ := cmd.Flags().GetString("heatmap-mode")
			if err := displayPerformanceHeatmap(cmd, heatmapMode); err != nil {
				log.Error("Failed to display performance heatmap", "error", err)
			}
		}
	},
	RunE: func(cmd *cobra.Command, args []string) error {
		// Check Atmos configuration.
		checkAtmosConfig()

		err := e.ExecuteAtmosCmd()
		return err
	},
}

// SetupLogger configures the global logger based on the provided Atmos configuration.
//
//nolint:revive,cyclop // Function complexity is acceptable for logger configuration.
func SetupLogger(atmosConfig *schema.AtmosConfiguration) {
	switch atmosConfig.Logs.Level {
	case "Trace":
		log.SetLevel(log.TraceLevel)
	case "Debug":
		log.SetLevel(log.DebugLevel)
	case "Info":
		log.SetLevel(log.InfoLevel)
	case "Warning":
		log.SetLevel(log.WarnLevel)
	case "Off":
		log.SetLevel(math.MaxInt32)
	default:
		log.SetLevel(log.WarnLevel)
	}

	// Get theme-aware log styles.
	var styles *log.Styles
	if atmosConfig.Settings.Terminal.IsColorEnabled(term.IsTTYSupportForStderr()) {
		// Get color scheme for the configured theme.
		scheme, err := theme.GetColorSchemeForTheme(atmosConfig.Settings.Terminal.Theme)
		if err == nil && scheme != nil {
			// Use themed styles.
			styles = theme.GetLogStyles(scheme)
		} else {
			// Fallback to default styles if theme loading fails.
			styles = log.DefaultStyles()
		}
	} else {
		// Use no-color styles.
		styles = theme.GetLogStylesNoColor()
	}

	// Add TRCE level for trace logging (using same style as DEBU).
	if debugStyle, ok := styles.Levels[log.DebugLevel]; ok {
		styles.Levels[log.TraceLevel] = debugStyle.SetString("TRCE")
	} else {
		styles.Levels[log.TraceLevel] = lipgloss.NewStyle().SetString("TRCE")
	}

	log.SetStyles(styles)
	// Only set output if a log file is configured.
	if atmosConfig.Logs.File != "" {
		var output io.Writer

		switch atmosConfig.Logs.File {
		case "/dev/stderr":
			output = iolib.MaskWriter(os.Stderr)
		case "/dev/stdout":
			output = iolib.MaskWriter(os.Stdout)
		case "/dev/null":
			output = io.Discard // More efficient than opening os.DevNull
		default:
			logFile, err := os.OpenFile(atmosConfig.Logs.File, os.O_CREATE|os.O_WRONLY|os.O_APPEND, logFileMode)
			errUtils.CheckErrorPrintAndExit(err, "Failed to open log file", "")
			// Store the file handle for later cleanup instead of deferring close.
			logFileHandle = logFile
			output = iolib.MaskWriter(logFile)
		}

		log.SetOutput(output)
	}
	if _, err := log.ParseLogLevel(atmosConfig.Logs.Level); err != nil {
		// Enrich the error with proper formatting for user-facing output.
		// The error from ParseLogLevel has format: "sentinel\nexplanation"
		// Extract the explanation text (everything after the first newline).
		errMsg := err.Error()
		parts := strings.SplitN(errMsg, "\n", 2)
		explanation := ""
		if len(parts) > 1 {
			explanation = parts[1]
		}

		// Build enriched error from the wrapped error, adding the explanation as a detail.
		// This ensures the formatter can extract both the sentinel message and the explanation.
		enrichedErr := errUtils.Build(log.ErrInvalidLogLevel).
			WithExplanation(explanation).
			Err()
		errUtils.CheckErrorPrintAndExit(enrichedErr, "", "")
	}
	log.Debug("Set", "logs-level", log.GetLevelString(), "logs-file", atmosConfig.Logs.File)
}

// configureEarlyColorProfile sets the lipgloss color profile based on environment variables.
// This is called early in PersistentPreRun, before config loading, to ensure that any
// theme styles accessed during stack processing respect NO_COLOR and other settings.
func configureEarlyColorProfile(cmd *cobra.Command) {
	// Check NO_COLOR environment variable (standard terminal env var).
	//nolint:forbidigo // Standard terminal env var, must use os.Getenv before config loads.
	if os.Getenv("NO_COLOR") != "" {
		// NO_COLOR is set - disable all colors
		lipgloss.SetColorProfile(termenv.Ascii)
		theme.InvalidateStyleCache() // Regenerate theme styles without colors
		return
	}

	// Check --no-color flag (already parsed by cobra at this point)
	if noColor, _ := cmd.Flags().GetBool("no-color"); noColor {
		lipgloss.SetColorProfile(termenv.Ascii)
		theme.InvalidateStyleCache()
		return
	}

	// Check --force-color flag
	if forceColor, _ := cmd.Flags().GetBool("force-color"); forceColor {
		lipgloss.SetColorProfile(termenv.TrueColor)
		theme.InvalidateStyleCache()
		return
	}

	// Note: Full color profile detection happens later in InitFormatter().
	// This early configuration just handles the most critical cases (NO_COLOR).
}

// setupColorProfile configures the global lipgloss color profile based on Atmos configuration.
func setupColorProfile(atmosConfig *schema.AtmosConfiguration) {
	defer perf.Track(atmosConfig, "root.setupColorProfile")()

	// Force TrueColor profile when ATMOS_FORCE_COLOR is enabled.
	// This bypasses terminal detection and always outputs ANSI color codes.
	if atmosConfig.Settings.Terminal.ForceColor {
		lipgloss.SetColorProfile(termenv.TrueColor)
		log.SetColorProfile(termenv.TrueColor)
		log.Debug("Forced TrueColor profile", "force_color", true)
	}
}

// setupColorProfileFromEnv checks ATMOS_FORCE_COLOR environment variable and --force-color flag early.
// This is called during init() before Boa styles are created, ensuring Cobra help
// text rendering respects the forced color profile.
func setupColorProfileFromEnv() {
	defer perf.Track(nil, "cmd.setupColorProfileFromEnv")()

	// Check environment variable first using global viper.
	// Note: ATMOS env prefix and AutomaticEnv are configured in init().
	forceColor := viper.GetBool("FORCE_COLOR")

	// Also check --force-color CLI flag by manually parsing os.Args.
	// This is needed because Cobra hasn't parsed flags yet during init().
	if !forceColor {
		for _, arg := range os.Args {
			if arg == "--force-color" {
				forceColor = true
				break
			}
		}
	}

	if forceColor {
		// Set both lipgloss profile AND CLICOLOR_FORCE environment variable.
		// Lipgloss respects SetColorProfile(), but Boa (help renderer) checks CLICOLOR_FORCE.
		lipgloss.SetColorProfile(termenv.TrueColor)
		_ = os.Setenv("CLICOLOR_FORCE", "1")
	}
}

// cleanupLogFile closes the log file handle if it was opened.
func cleanupLogFile() {
	if logFileHandle != nil {
		// Flush any remaining log data before closing.
		_ = logFileHandle.Sync()
		_ = logFileHandle.Close()
		logFileHandle = nil
	}
}

// Cleanup performs cleanup operations before the program exits.
// This should be called by main when the program is terminating.
func Cleanup() {
	cleanupLogFile()
}

// RenderFlags renders a flag set with colors and proper text wrapping.
// Flag names are colored green, flag types are dimmed, descriptions are wrapped to terminal width.
// Markdown in descriptions is rendered to terminal output.

// flagRenderLayout holds layout constants and dimensions for flag rendering.
type flagRenderLayout struct {
	leftPad      int
	spaceBetween int
	rightMargin  int
	minDescWidth int
	maxFlagWidth int
	descColStart int
	descWidth    int
}

// newFlagRenderLayout creates a new layout configuration for flag rendering.
func newFlagRenderLayout(termWidth int, maxFlagWidth int) flagRenderLayout {
	const (
		leftPad      = 2
		spaceBetween = 2
		rightMargin  = 2
		minDescWidth = 40
	)

	descColStart := leftPad + maxFlagWidth + spaceBetween
	descWidth := termWidth - descColStart - rightMargin
	if descWidth < minDescWidth {
		descWidth = minDescWidth
	}

	return flagRenderLayout{
		leftPad:      leftPad,
		spaceBetween: spaceBetween,
		rightMargin:  rightMargin,
		minDescWidth: minDescWidth,
		maxFlagWidth: maxFlagWidth,
		descColStart: descColStart,
		descWidth:    descWidth,
	}
}

// calculateMaxFlagWidth finds the maximum flag name width for alignment.
func calculateMaxFlagWidth(flags *pflag.FlagSet) int {
	maxWidth := 0
	flags.VisitAll(func(f *pflag.Flag) {
		if f.Hidden {
			return
		}
		flagName := formatFlagName(f)
		if len(flagName) > maxWidth {
			maxWidth = len(flagName)
		}
	})
	return maxWidth
}

// buildFlagDescription creates the flag description with default value if applicable.
func buildFlagDescription(f *pflag.Flag) string {
	usage := f.Usage
	if f.DefValue != "" && f.DefValue != "false" && f.DefValue != "0" && f.DefValue != "[]" && f.Name != "" && f.Name != "help" {
		usage += fmt.Sprintf(" (default `%s`)", f.DefValue)
	}
	return usage
}

// renderWrappedLines renders wrapped description lines with proper indentation.
func renderWrappedLines(w io.Writer, lines []string, indent int, descStyle *lipgloss.Style) {
	if len(lines) == 0 {
		return
	}

	// Print first line (already positioned on same line as flag name)
	fmt.Fprintf(w, "%s\n", descStyle.Render(lines[0]))

	// Print continuation lines with proper indentation
	indentStr := strings.Repeat(" ", indent)
	for i := 1; i < len(lines); i++ {
		fmt.Fprintf(w, "%s%s\n", indentStr, descStyle.Render(lines[i]))
	}
}

func isCompletionCommand(cmd *cobra.Command) bool {
	if cmd == nil {
		return false
	}

	// Check the command name directly from the Cobra command
	// This works for both os.Args and SetArgs() invocations
	cmdName := cmd.Name()
	if cmdName == "completion" || cmdName == "__complete" || cmdName == "__completeNoDesc" {
		return true
	}

	// Also check for shell completion environment variables
	// Cobra sets these when generating completions
	//nolint:forbidigo // These are external shell variables, not Atmos config
	if os.Getenv("COMP_LINE") != "" || os.Getenv("_ARGCOMPLETE") != "" {
		return true
	}

	return false
}

// findExperimentalParent walks up the command tree to find if any command in the
// chain is experimental. Returns the name of the experimental command, or empty
// string if none found. This allows subcommands to inherit experimental status
// from their parent (e.g., "atmos devcontainer list" triggers the devcontainer warning).
//
// The function uses a two-pass approach:
//  1. First, check for registry-based experimental commands (top-level like devcontainer, toolchain).
//     These are the "original" experimental commands and should be preferred.
//  2. Second, check for annotation-based experimental subcommands (like terraform backend).
//     This handles explicit subcommand-level experimental status.
//
// This ordering ensures that "devcontainer list" returns "devcontainer" (the registered
// experimental parent) rather than "list" (which inherited the annotation).
func findExperimentalParent(cmd *cobra.Command) string {
	// First pass: Look for registry-based experimental commands.
	// These are top-level commands like devcontainer, toolchain.
	for c := cmd; c != nil; c = c.Parent() {
		if internal.IsCommandExperimental(c.Name()) {
			return c.Name()
		}
	}

	// Second pass: Look for annotation-based experimental subcommands.
	// These are subcommands explicitly marked experimental like "terraform backend".
	for c := cmd; c != nil; c = c.Parent() {
		if c.Annotations != nil && c.Annotations["experimental"] == "true" {
			return c.Name()
		}
	}

	return ""
}

// checkExperimentalSettings checks if any experimental settings are enabled in the config
// and applies the same experimental mode handling (silence/warn/error/disable) as commands.
// This extends the experimental system to cover non-command features gated by config values.
func checkExperimentalSettings(atmosConfig *schema.AtmosConfiguration) {
	if atmosConfig == nil {
		return
	}

	// Collect experimental settings that are enabled.
	var features []string
	if atmosConfig.Settings.YAML.KeyDelimiter != "" {
		features = append(features, "settings.yaml.key_delimiter")
	}

	if len(features) == 0 {
		return
	}

	experimentalMode := atmosConfig.Settings.Experimental
	if experimentalMode == "" {
		experimentalMode = "warn"
	}

	for _, feature := range features {
		switch experimentalMode {
		case "silence":
			// Do nothing.
		case "disable":
			errUtils.CheckErrorPrintAndExit(
				errUtils.Build(errUtils.ErrExperimentalDisabled).
					WithContext("setting", feature).
					WithHint("Enable with settings.experimental: warn").
					Err(),
				"", "",
			)
		case "warn":
			ui.Experimental(feature)
		case "error":
			ui.Experimental(feature)
			errUtils.CheckErrorPrintAndExit(
				errUtils.Build(errUtils.ErrExperimentalRequiresIn).
					WithContext("setting", feature).
					WithHint("Enable with settings.experimental: warn").
					Err(),
				"", "",
			)
		}
	}
}

// flagStyles holds the lipgloss styles for flag rendering.
type flagStyles struct {
	flagStyle    lipgloss.Style
	argTypeStyle lipgloss.Style
	descStyle    lipgloss.Style
}

// renderSingleFlag renders one flag with its description.
func renderSingleFlag(w io.Writer, f *pflag.Flag, layout flagRenderLayout, styles *flagStyles, renderer *markdown.Renderer) {
	// Get flag name parts and calculate padding
	flagNamePlain, flagTypePlain := formatFlagNameParts(f)
	fullPlainLength := len(flagNamePlain)
	if flagTypePlain != "" {
		fullPlainLength += 1 + len(flagTypePlain)
	}
	padding := layout.maxFlagWidth - fullPlainLength

	const space = " "

	// Render flag name with colors
	fmt.Fprint(w, strings.Repeat(space, layout.leftPad))
	fmt.Fprint(w, styles.flagStyle.Render(flagNamePlain))
	if flagTypePlain != "" {
		fmt.Fprint(w, space)
		fmt.Fprint(w, styles.argTypeStyle.Render(flagTypePlain))
	}
	fmt.Fprint(w, strings.Repeat(space, padding+layout.spaceBetween))

	// Build and process description
	usage := buildFlagDescription(f)
	wrapped := wordwrap.String(usage, layout.descWidth)

	if renderer != nil {
		rendered, err := renderer.RenderWithoutWordWrap(wrapped)
		if err == nil {
			wrapped = atmosansi.TrimLinesRight(rendered)
		}
	}

	lines := strings.Split(wrapped, "\n")
	renderWrappedLines(w, lines, layout.descColStart, &styles.descStyle)

	fmt.Fprintln(w)
}

// renderFlags renders all flags with formatting and styling.
//
//nolint:revive,gocritic // Function signature required for compatibility with help template system.
func renderFlags(w io.Writer, flags *pflag.FlagSet, flagStyle, argTypeStyle, descStyle lipgloss.Style, termWidth int, atmosConfig *schema.AtmosConfiguration) {
	defer perf.Track(atmosConfig, "cmd.renderFlags")()

	if flags == nil {
		return
	}

	maxFlagWidth := calculateMaxFlagWidth(flags)
	layout := newFlagRenderLayout(termWidth, maxFlagWidth)

	styles := &flagStyles{
		flagStyle:    flagStyle,
		argTypeStyle: argTypeStyle,
		descStyle:    descStyle,
	}

	renderer, err := markdown.NewTerminalMarkdownRenderer(*atmosConfig)
	if err != nil {
		renderer = nil
	}

	flags.VisitAll(func(f *pflag.Flag) {
		if f.Hidden {
			return
		}
		renderSingleFlag(w, f, layout, styles, renderer)
	})
}

// formatFlagNameParts returns the flag name and type as separate strings for independent styling.
// Returns (flagName, flagType) where flagType may be empty for bool flags.
// Aligns all long flags (--name) at the same column regardless of shorthand presence.
func formatFlagNameParts(f *pflag.Flag) (string, string) {
	// Get the flag type (e.g., "string", "int", "bool")
	flagType := f.Value.Type()

	// Build flag name (without type)
	// Align long flags at column: "  " (leftPad=2) + "-X, " (4 chars for shorthand)
	// So long-only flags need 4 spaces before "--" to align with shorthand flags
	var flagName string
	if f.Shorthand == "" {
		flagName = fmt.Sprintf("    --%s", f.Name) // 4 spaces to align with "-X, --"
	} else {
		flagName = fmt.Sprintf("-%s, --%s", f.Shorthand, f.Name) // "-X, --name"
	}

	// For bool flags, don't return a type
	if flagType == "bool" {
		return flagName, ""
	}

	// Replace "stringSlice" with "strings" for better readability
	if flagType == "stringSlice" {
		flagType = "strings"
	}

	return flagName, flagType
}

// formatFlagName formats a flag with its shorthand (if any) and type in Cobra style.
// This is used for calculating maximum width.
func formatFlagName(f *pflag.Flag) string {
	flagName, flagType := formatFlagNameParts(f)
	if flagType != "" {
		return flagName + " " + flagType
	}
	return flagName
}

// getTerminalWidth returns the current terminal width, with a fallback default.
func getTerminalWidth() int {
	const defaultWidth = 120 // Fang's max width
	width, _, err := xterm.GetSize(os.Stdout.Fd())
	if err != nil || width <= 0 {
		return defaultWidth
	}
	if width > defaultWidth {
		return defaultWidth // Cap at maximum for readability
	}
	return width
}

// findAnsiCodeEnd finds the index where an ANSI escape code ends (at a letter).
func findAnsiCodeEnd(s string) int {
	for i := 0; i < len(s); i++ {
		if (s[i] >= 'A' && s[i] <= 'Z') || (s[i] >= 'a' && s[i] <= 'z') {
			return i
		}
	}
	return -1
}

// isBackgroundCode checks if an ANSI code is a background color code (48;...).
func isBackgroundCode(ansiCode string) bool {
	return strings.HasPrefix(ansiCode, "48;") || strings.Contains(ansiCode, ";48;")
}

// stripBackgroundFromSGR strips background color parameters from an SGR sequence.
func stripBackgroundFromSGR(sgrParams string) string {
	// Remove trailing 'm' if present for easier processing.
	params := strings.TrimSuffix(sgrParams, "m")
	if params == "" {
		return sgrParams
	}

	parts := strings.Split(params, ";")
	var filtered []string
	i := 0

	for i < len(parts) {
		part := parts[i]

		// Check if this is a background color sequence (48).
		if part != "48" {
			// Keep foreground and other codes.
			filtered = append(filtered, part)
			i++
			continue
		}

		// Skip 48 and its associated parameters.
		i++
		if i >= len(parts) {
			continue
		}

		// Handle different background color types.
		switch parts[i] {
		case "2":
			// TrueColor: 48;2;r;g;b - skip 5 parts total (48, 2, r, g, b).
			i += 4 // Skip 2, r, g, b (already skipped 48).
		case "5":
			// 256 color: 48;5;n - skip 3 parts total (48, 5, n).
			i += 2 // Skip 5, n (already skipped 48).
		}
	}

	if len(filtered) == 0 {
		return ""
	}

	return strings.Join(filtered, ";") + "m"
}

// processAnsiEscapeSequence processes a single ANSI escape sequence part.
func processAnsiEscapeSequence(part string) (codeToKeep string, remainder string) {
	endIdx := findAnsiCodeEnd(part)
	if endIdx == -1 {
		// No ending found, keep entire part as-is.
		return ansiEscapePrefix + part, ""
	}

	ansiCode := part[:endIdx+1]
	remainder = part[endIdx+1:]

	// Check if this is a combined sequence with background color.
	if isBackgroundCode(ansiCode) {
		// Strip background parts but keep foreground.
		stripped := stripBackgroundFromSGR(ansiCode)
		if stripped != "" {
			codeToKeep = ansiEscapePrefix + stripped
		}
	} else {
		// No background, keep entire sequence.
		codeToKeep = ansiEscapePrefix + ansiCode
	}

	return codeToKeep, remainder
}

// StripBackgroundCodes removes background ANSI color codes (ESC[48;...) while preserving foreground colors.
// This allows markdown-rendered content to be displayed on our custom background without conflicts.
//
//nolint:godot // Function comment format acceptable despite linter warning.
func stripBackgroundCodes(s string) string {
	defer perf.Track(nil, "cmd.stripBackgroundCodes")()

	parts := strings.Split(s, ansiEscapePrefix)
	if len(parts) == 0 {
		return s
	}

	// First part has no escape sequence.
	result := parts[0]

	// Process remaining parts (each starts with an ANSI code).
	for i := 1; i < len(parts); i++ {
		codeToKeep, remainder := processAnsiEscapeSequence(parts[i])
		result += codeToKeep + remainder
	}

	return result
}

// applyColoredHelpTemplate applies a custom colored help template using colorprofile.Writer and lipgloss.
// This approach ensures colors work in both interactive terminals and redirected output (screengrabs).
// Colors are automatically enabled when ATMOS_FORCE_COLOR, CLICOLOR_FORCE, or FORCE_COLOR is set.

// setupProfiler initializes and starts the profiler if enabled.
func setupProfiler(cmd *cobra.Command, atmosConfig *schema.AtmosConfiguration) error {
	// Build profiler configuration from multiple sources.
	profilerConfig, err := buildProfilerConfig(cmd, atmosConfig)
	if err != nil {
		return err
	}

	// Skip when not enabled (server) and no file-based profiling requested.
	if !profilerConfig.Enabled && profilerConfig.File == "" {
		return nil
	}

	// Create and start the profiler.
	profilerServer = profiler.New(profilerConfig)
	if err := profilerServer.Start(); err != nil {
		return fmt.Errorf("%w: failed to start profiler: %v", errUtils.ErrProfilerStart, err)
	}

	return nil
}

// buildProfilerConfig constructs profiler configuration from environment and CLI flags.
func buildProfilerConfig(cmd *cobra.Command, atmosConfig *schema.AtmosConfiguration) (profiler.Config, error) {
	// Start with environment/config values or defaults.
	profilerConfig := getBaseProfilerConfig(atmosConfig)

	// Apply environment variable overrides.
	if err := applyProfilerEnvironmentOverrides(&profilerConfig, atmosConfig); err != nil {
		return profilerConfig, err
	}

	// Apply CLI flag overrides.
	if err := applyCLIFlagOverrides(&profilerConfig, cmd); err != nil {
		return profilerConfig, err
	}

	return profilerConfig, nil
}

// getBaseProfilerConfig returns the base configuration from the config file or defaults.
func getBaseProfilerConfig(atmosConfig *schema.AtmosConfiguration) profiler.Config {
	profilerConfig := atmosConfig.Profiler

	// Check if the profiler config is completely empty.
	isEmpty := profilerConfig.Host == "" &&
		profilerConfig.Port == 0 &&
		profilerConfig.File == "" &&
		profilerConfig.ProfileType == "" &&
		!profilerConfig.Enabled

	if isEmpty {
		return profiler.DefaultConfig()
	}

	// Default individual fields independently to avoid partial configurations.
	defaultConfig := profiler.DefaultConfig()
	if profilerConfig.Host == "" {
		profilerConfig.Host = defaultConfig.Host
	}
	if profilerConfig.Port == 0 {
		profilerConfig.Port = defaultConfig.Port
	}
	if profilerConfig.ProfileType == "" {
		profilerConfig.ProfileType = defaultConfig.ProfileType
	}

	return profilerConfig
}

// applyProfilerEnvironmentOverrides applies environment variable values to profiler config.
func applyProfilerEnvironmentOverrides(config *profiler.Config, atmosConfig *schema.AtmosConfiguration) error {
	if atmosConfig.Profiler.Host != "" {
		config.Host = atmosConfig.Profiler.Host
	}
	if atmosConfig.Profiler.Port != 0 {
		config.Port = atmosConfig.Profiler.Port
	}
	if atmosConfig.Profiler.File != "" {
		config.File = atmosConfig.Profiler.File
		// Enable profiler automatically when a file is specified via ENV var.
		config.Enabled = true
	}
	if atmosConfig.Profiler.ProfileType != "" {
		parsedType, parseErr := profiler.ParseProfileType(string(atmosConfig.Profiler.ProfileType))
		if parseErr != nil {
			return fmt.Errorf("%w: invalid ATMOS_PROFILE_TYPE %q: %v", errUtils.ErrParseFlag, atmosConfig.Profiler.ProfileType, parseErr)
		}
		config.ProfileType = parsedType
	}
	if atmosConfig.Profiler.Enabled {
		config.Enabled = atmosConfig.Profiler.Enabled
	}

	return nil
}

// applyCLIFlagOverrides applies CLI flag values to profiler config.
func applyCLIFlagOverrides(config *profiler.Config, cmd *cobra.Command) error {
	applyBoolFlag(cmd, "profiler-enabled", func(val bool) { config.Enabled = val })
	applyIntFlag(cmd, "profiler-port", func(val int) { config.Port = val })
	applyStringFlag(cmd, "profiler-host", func(val string) { config.Host = val })

	if err := applyProfileFileFlag(config, cmd); err != nil {
		return err
	}

	if err := applyProfileTypeFlag(config, cmd); err != nil {
		return err
	}

	return nil
}

// applyBoolFlag applies a boolean CLI flag to the config.
func applyBoolFlag(cmd *cobra.Command, flagName string, setter func(bool)) {
	if cmd.Flags().Changed(flagName) {
		if val, err := cmd.Flags().GetBool(flagName); err == nil {
			setter(val)
		}
	}
}

// applyIntFlag applies an integer CLI flag to the config.
func applyIntFlag(cmd *cobra.Command, flagName string, setter func(int)) {
	if cmd.Flags().Changed(flagName) {
		if val, err := cmd.Flags().GetInt(flagName); err == nil {
			setter(val)
		}
	}
}

// applyStringFlag applies a string CLI flag to the config.
func applyStringFlag(cmd *cobra.Command, flagName string, setter func(string)) {
	if cmd.Flags().Changed(flagName) {
		if val, err := cmd.Flags().GetString(flagName); err == nil {
			setter(val)
		}
	}
}

// applyProfileFileFlag applies the profile-file flag with auto-enable logic.
func applyProfileFileFlag(config *profiler.Config, cmd *cobra.Command) error {
	if cmd.Flags().Changed("profile-file") {
		file, err := cmd.Flags().GetString("profile-file")
		if err == nil {
			config.File = file
			// Enable profiler automatically when file is specified
			if file != "" {
				config.Enabled = true
			}
		}
	}
	return nil
}

// applyProfileTypeFlag applies the profile-type flag with validation.
func applyProfileTypeFlag(config *profiler.Config, cmd *cobra.Command) error {
	if !cmd.Flags().Changed("profile-type") {
		return nil
	}

	profileType, err := cmd.Flags().GetString("profile-type")
	if err != nil {
		return fmt.Errorf("%w: failed to get profile-type flag: %v", errUtils.ErrInvalidFlag, err)
	}

	parsedType, parseErr := profiler.ParseProfileType(profileType)
	if parseErr != nil {
		return fmt.Errorf("%w: invalid profile type '%s': %v", errUtils.ErrParseFlag, profileType, parseErr)
	}

	config.ProfileType = parsedType
	return nil
}

// ExecuteVersion prints the version information.
// This is called by main.main() when --version flag is detected at the application entry point.
// Handling version here (instead of in PersistentPreRun) eliminates the deep exit,
// allowing tests to run normally without triggering os.Exit in Go 1.25+.
func ExecuteVersion() error {
	// Initialize minimal config for version command (may not find atmos.yaml, which is OK).
	tmpConfig, _ := cfg.InitCliConfig(schema.ConfigAndStacksInfo{}, false)

	// Set up logger to ensure debug/trace messages appear.
	SetupLogger(&tmpConfig)

	return e.NewVersionExec(&tmpConfig).Execute(false, "")
}

// handleConfigInitError processes config initialization errors and enriches them for display.
// Returns nil if the error can be ignored (e.g., for version command), or an enriched error.
func handleConfigInitError(initErr error, atmosConfig *schema.AtmosConfiguration) error {
	if isVersionCommand() {
		// Version command should always work, even with invalid config.
		log.Debug("Warning: CLI configuration error (continuing for version command)", "error", initErr)
		return nil
	}

	if errors.Is(initErr, cfg.NotFound) {
		// Config not found is acceptable for some commands.
		return nil
	}

	// For invalid log level errors, enrich with explanation and markdown formatting.
	if errors.Is(initErr, log.ErrInvalidLogLevel) {
		// Extract explanation from error message (format: "sentinel\nexplanation").
		errMsg := initErr.Error()
		parts := strings.SplitN(errMsg, "\n", 2)
		explanation := ""
		if len(parts) > 1 {
			explanation = parts[1]
		}

		// Initialize markdown renderer even with partial config for error formatting.
		// This is safe because atmosConfig struct exists even if validation failed.
		errUtils.InitializeMarkdown(atmosConfig)

		// Build enriched error with explanation.
		return errUtils.Build(log.ErrInvalidLogLevel).
			WithExplanation(explanation).
			Err()
	}

	// Return other errors as-is.
	return initErr
}

// Execute adds all child commands to the root command and sets flags appropriately.
// Execute runs the root CLI command and performs one-time global startup tasks.
// It processes a leading --chdir before loading configuration, loads and wires the CLI
// configuration to subsystems, initializes markdown rendering and logging, registers
// custom commands and aliases (unless running the version command), executes the root
// command, captures telemetry, and handles unknown-command errors by showing usage.
// This function is invoked once from main.main.
func Execute() error {
	// CRITICAL: Process --chdir flag BEFORE loading config.
	// This ensures atmos.yaml is loaded from the correct directory when using --chdir.
	// We must process chdir early because aliases depend on the config, and the config
	// depends on the working directory.
	//
	// Note: We create a temporary command to parse flags because RootCmd hasn't been
	// fully initialized yet (custom commands/aliases not added). This is safe because
	// --chdir is a global persistent flag defined in init().
	if err := processEarlyChdirFlag(); err != nil {
		return err
	}

	// InitCliConfig finds and merges CLI configurations in the following order:
	// system dir, home dir, current dir, ENV vars, command-line arguments
	// Here we need the custom commands from the config.
	// Note: --version flag is now handled in main.go before calling Execute().
	var initErr error
	atmosConfig, initErr = cfg.InitCliConfig(schema.ConfigAndStacksInfo{}, false)

	// Set atmosConfig for commands that need access to config.
	version.SetAtmosConfig(&atmosConfig)
	devcontainer.SetAtmosConfig(&atmosConfig)
	themeCmd.SetAtmosConfig(&atmosConfig)
	backend.SetAtmosConfig(&atmosConfig)
	toolchainCmd.SetAtmosConfig(&atmosConfig)
	toolchain.SetAtmosConfig(&atmosConfig)
	workdir.SetAtmosConfig(&atmosConfig)

	if initErr != nil {
		// Handle config initialization errors based on command context.
		if err := handleConfigInitError(initErr, &atmosConfig); err != nil {
			return err
		}
		// Only log "not found" message when the error is specifically NotFound.
		// Other cases (e.g., version command with invalid config) log differently
		// inside handleConfigInitError.
		if errors.Is(initErr, cfg.NotFound) {
			log.Debug("Warning: CLI configuration 'atmos.yaml' file not found", "error", initErr)
		}
	}

	// Initialize markdown renderers only if config loaded successfully
	// This prevents deep exits in InitializeMarkdown when config is invalid
	if initErr == nil {
		utils.InitializeMarkdown(&atmosConfig)
		errUtils.InitializeMarkdown(&atmosConfig)
	}

	// Set the log level for the charmbracelet/log package based on the atmosConfig.
	SetupLogger(&atmosConfig)

	// Setup color profile for lipgloss/termenv based rendering.
	setupColorProfile(&atmosConfig)

	var err error
	// If CLI configuration was found, process its custom commands and command aliases.
	// Skip processing for version command to ensure it always works, even if aliases
	// reference commands that don't exist in this version of Atmos.
	if initErr == nil && !isVersionCommand() {
		err = processCustomCommands(atmosConfig, atmosConfig.Commands, RootCmd, true)
		if err != nil {
			return err
		}

		err = processCommandAliases(atmosConfig, atmosConfig.CommandAliases, RootCmd, true)
		if err != nil {
			return err
		}
	}

	// Boa styling is already applied via RootCmd.SetHelpFunc() which is inherited by all subcommands.
	// No need to recursively set UsageFunc as that would override Boa's handling.

	// Preprocess args for commands with compatibility flags.
	// This separates Atmos flags from pass-through flags BEFORE Cobra parses.
	preprocessCompatibilityFlags()

	// Cobra for some reason handles root command in such a way that custom usage and help command don't work as per expectations.
	RootCmd.SilenceErrors = true
	cmd, err := internal.Execute(RootCmd)

	telemetry.CaptureCmd(cmd, err)

	// Handle sentinel errors with errors.Is().
	if err != nil {
		if errors.Is(err, errUtils.ErrCommandNotFound) {
			command, _ := errUtils.GetContext(err, "command")
			showUsageAndExit(RootCmd, []string{command})
		}
	}
	return err
}

// preprocessCompatibilityFlags separates Atmos flags from pass-through flags.
// This is called BEFORE Cobra parses, allowing us to filter out terraform/helmfile
// native flags that would otherwise be dropped by FParseErrWhitelist.
//
// It also normalizes flags with NoOptDefVal (like --identity) to ensure both
// "--flag value" and "--flag=value" syntax work correctly, using the existing
// FlagRegistry.PreprocessNoOptDefValArgs from the command's registered flag registry.
//
// The separated args are stored globally via compat.SetSeparated() and can be
// retrieved in RunE via compat.GetSeparated().
func preprocessCompatibilityFlags() {
	osArgs := os.Args[1:]
	if len(osArgs) == 0 {
		return
	}

	// Find target command without parsing flags.
	targetCmd, _, _ := RootCmd.Find(osArgs)
	if targetCmd == nil {
		return
	}

	// Get the top-level command name (e.g., "terraform").
	// Walk up the command tree to find the first non-root command.
	cmdName := ""
	for c := targetCmd; c != nil && c != RootCmd; c = c.Parent() {
		cmdName = c.Name()
	}
	if cmdName == "" {
		return
	}

	// Normalize flags with NoOptDefVal using the command's registered flag registry.
	// This converts "--identity value" to "--identity=value" so pflag correctly
	// captures the value instead of using NoOptDefVal and orphaning the value arg.
	// Uses the same PreprocessNoOptDefValArgs that AtmosFlagParser.Parse() uses,
	// driven by the flag registry rather than a hardcoded flag map.
	argsChanged := false
	if flagRegistry := internal.GetCommandFlagRegistry(cmdName); flagRegistry != nil {
		normalized := flagRegistry.PreprocessNoOptDefValArgs(osArgs)
		if len(normalized) != len(osArgs) {
			osArgs = normalized
			argsChanged = true
		}
	}

	// Get compatibility flags from the command registry.
	compatFlags := internal.GetCompatFlagsForCommand(cmdName)
	if len(compatFlags) == 0 {
		// No compat flags, but still apply normalization if args changed.
		if argsChanged {
			RootCmd.SetArgs(osArgs)
		}
		return
	}

	// Translate args: separate Atmos flags from pass-through flags.
	translator := compat.NewCompatibilityFlagTranslator(compatFlags)
	atmosArgs, separatedArgs := translator.Translate(osArgs)

	// Give Cobra only the Atmos args.
	RootCmd.SetArgs(atmosArgs)

	// Store separated args globally via compat package.
	compat.SetSeparated(separatedArgs)
}

// displayPerformanceHeatmap shows the performance heatmap visualization.
//
// ConvertToTermenvProfile converts our terminal.ColorProfile to termenv.Profile.
//
//nolint:unparam // cmd parameter reserved for future use
func convertToTermenvProfile(profile terminal.ColorProfile) termenv.Profile {
	switch profile {
	case terminal.ColorNone:
		return termenv.Ascii
	case terminal.Color16:
		return termenv.ANSI
	case terminal.Color256:
		return termenv.ANSI256
	case terminal.ColorTrue:
		return termenv.TrueColor
	default:
		// Default to ASCII (no color) for unknown profiles.
		return termenv.Ascii
	}
}

func displayPerformanceHeatmap(cmd *cobra.Command, mode string) error {
	// Print performance summary to console, filtering out zero-time functions.
	snap := perf.SnapshotTopFiltered("total", defaultTopFunctionsMax)
	utils.PrintfMessageToTUI("\n=== Atmos Performance Summary ===\n")
	utils.PrintfMessageToTUI("Elapsed: %s  Functions: %d  Calls: %d\n", snap.Elapsed, snap.TotalFuncs, snap.TotalCalls)
	utils.PrintfMessageToTUI("%-50s %6s %10s %10s %10s %8s\n", "Function", "Count", "Total", "Avg", "Max", "P95")
	for _, r := range snap.Rows {
		p95 := "-"
		if r.P95 > 0 {
			p95 = heatmap.FormatDuration(r.P95)
		}
		utils.PrintfMessageToTUI("%-50s %6d %10s %10s %10s %8s\n",
			r.Name, r.Count, heatmap.FormatDuration(r.Total), heatmap.FormatDuration(r.Avg), heatmap.FormatDuration(r.Max), p95)
	}

	// Check if we have a TTY for interactive mode.
	if !term.IsTTYSupportForStderr() {
		utils.PrintfMessageToTUI("\n⚠️  No TTY available for interactive visualization. Summary displayed above.\n")
		return nil
	}

	// Create an empty heat model for now (we'll enhance this later to track actual execution steps).
	heatModel := heatmap.NewHeatModel()

	// Create context that cancels on SIGINT/SIGTERM.
	base := context.Background()
	sigCtx, stop := signal.NotifyContext(base, syscall.SIGINT, syscall.SIGTERM)
	defer stop()

	// Start Bubble Tea UI with the collected data.
	return heatmap.StartBubbleTeaUI(sigCtx, heatModel, mode)
}

// init initializes CLI wiring for the package: it registers built-in commands, adds template helpers, registers and binds global persistent flags and related environment variables, adjusts the version flag default, sets the custom usage template, and configures Cobra behavior for the root command.
// This prepares global flag precedence, environment bindings (color, mask, verbose, GitHub token), and other root-level CLI integrations before command execution.
func init() {
	// Register all global flags as persistent flags using builder pattern.
	// IMPORTANT: This MUST happen BEFORE registering commands, so commands inherit the persistent flags.
	// Global flags are registered as persistent so they're inherited by all subcommands.
	// This provides:
	//   - Single source of truth for defaults (NewGlobalFlags())
	//   - Automatic environment variable binding
	//   - Consistent with other command builders
	//   - Testable flag precedence
	globalParser := flags.NewGlobalOptionsBuilder().Build()
	globalParser.RegisterPersistentFlags(RootCmd)
	if err := globalParser.BindToViper(viper.GetViper()); err != nil {
		log.Error("Failed to bind global flags to viper", "error", err)
	}

	// Register --version as a LOCAL flag (not inherited by subcommands).
	// This allows custom commands to define their own --version flag (e.g., for tool versions).
	// The flag is only meaningful on the root command and is handled specially in main.go
	// before Execute() is called.
	RootCmd.Flags().Bool("version", false, "Display the Atmos CLI version")

	// Register built-in commands from the registry.
	// This must happen AFTER persistent flags are registered so commands inherit them.
	// Commands register themselves via init() functions when their packages
	// are imported with blank imports (e.g., _ "github.com/cloudposse/atmos/cmd/about").
	if err := internal.RegisterAll(RootCmd); err != nil {
		log.Error("Failed to register built-in commands", "error", err)
	}

	// Add the template function for wrapped flag usages.
	cobra.AddTemplateFunc("wrappedFlagUsages", templates.WrappedFlagUsages)

	// Special handling for version flag: clear DefValue for cleaner --help output.
	// Note: --version is a LOCAL flag (not persistent), so use Flags() not PersistentFlags().
	if versionFlag := RootCmd.Flags().Lookup("version"); versionFlag != nil {
		versionFlag.DefValue = ""
	}
	// Configure viper for automatic environment variable binding.
	// This must happen before setupColorProfileFromEnv() uses viper.GetBool("FORCE_COLOR").
	viper.SetEnvPrefix("ATMOS")
	viper.AutomaticEnv()

	// Bind both ATMOS_FORCE_COLOR and CLICOLOR_FORCE to the same viper key (they are equivalent).
	if err := viper.BindEnv("force-color", "ATMOS_FORCE_COLOR", "CLICOLOR_FORCE"); err != nil {
		log.Error("Failed to bind ATMOS_FORCE_COLOR/CLICOLOR_FORCE environment variables", "error", err)
	}
	// Bind mask flag to Viper so viper.GetBool("mask") reads the flag value.
	if err := viper.BindPFlag("mask", RootCmd.PersistentFlags().Lookup("mask")); err != nil {
		log.Error("Failed to bind mask flag to Viper", "error", err)
	}
	// Bind mask flag to environment variable.
	if err := viper.BindEnv("mask", "ATMOS_MASK"); err != nil {
		log.Error("Failed to bind ATMOS_MASK environment variable", "error", err)
	}
	// Bind verbose flag to environment variable.
	if err := viper.BindEnv(verboseFlagName, "ATMOS_VERBOSE"); err != nil {
		log.Error("Failed to bind ATMOS_VERBOSE environment variable", "error", err)
	}

	// Setup color profile early for Cobra/Boa styling.
	// This must happen before initCobraConfig() creates Boa styles.
	setupColorProfileFromEnv()

	// Note: GitHub token is now bound via GlobalOptionsBuilder in pkg/flags/global_builder.go.
	// It supports both ATMOS_GITHUB_TOKEN and GITHUB_TOKEN environment variables,
	// and can be overridden with the --github-token CLI flag.

	// Note: Toolchain command is now registered via the command registry pattern.
	// The blank import of cmd/toolchain automatically registers it.

	// Set custom usage template.
	err := templates.SetCustomUsageFunc(RootCmd)
	if err != nil {
		errUtils.CheckErrorPrintAndExit(err, "", "")
	}

	// Initialize I/O context and global formatter early in init().
	// This ensures I/O is available for help commands and other early operations.
	// Note: Flags are not yet parsed at this point, so this uses default/env settings.
	// PersistentPreRun will re-initialize with flag overrides if needed.
	ioCtx, ioErr := iolib.NewContext()
	if ioErr != nil {
		log.Error("Failed to initialize I/O context", "error", ioErr)
		// Fail fast: I/O context is critical for all output operations.
		// Without it, ui.Format and data.Writer are unset, risking nil-pointer panics.
		errUtils.CheckErrorPrintAndExit(ioErr, "Failed to initialize I/O context", "")
	}
	ui.InitFormatter(ioCtx)
	data.InitWriter(ioCtx)
	data.SetMarkdownRenderer(ui.Format) // Connect markdown rendering to data channel

	initCobraConfig()
}

// initCobraConfig initializes Cobra command configuration and styling.
func initCobraConfig() {
	RootCmd.SetOut(os.Stdout)
	styles := boa.DefaultStyles()
	b := boa.New(boa.WithStyles(styles))
	RootCmd.SetFlagErrorFunc(func(c *cobra.Command, err error) error {
		return showFlagUsageAndExit(c, err)
	})
	RootCmd.SetUsageFunc(func(c *cobra.Command) error {
		if c.Use == "atmos" {
			return b.UsageFunc(c)
		}
		// Get actual arguments (handles DisableFlagParsing=true case).
		arguments := flags.GetActualArgs(c, os.Args)

		// IMPORTANT: Check if command has Args validator and args are valid.
		// If args pass validation, they're positional args, not unknown subcommands.
		// This prevents "Unknown command component1" errors for valid positional args.
		if len(arguments) > 0 {
			if err := flags.ValidateArgsOrNil(c, arguments); err == nil {
				// Args are valid positional arguments - show usage without "Unknown command" error
				showErrorExampleFromMarkdown(c, "")
				errUtils.Exit(1)
				return nil
			}
			// Args validation failed - fall through to show error with first arg as unknown command
		}

		showUsageAndExit(c, arguments)
		return nil
	})
	RootCmd.SetHelpFunc(func(command *cobra.Command, args []string) {
		contentName := strings.ReplaceAll(strings.ReplaceAll(command.CommandPath(), " ", "_"), "-", "_")
		if exampleContent, ok := examples[contentName]; ok {
			command.Example = exampleContent.Content
		}

		// Check if help was explicitly requested via os.Args, args parameter, or via the help flag.
		helpRequested := Contains(os.Args, "help") || Contains(os.Args, "--help") || Contains(os.Args, "-h") ||
			Contains(args, "help") || Contains(args, "--help") || Contains(args, "-h")
		if helpFlag := command.Flag("help"); helpFlag != nil && helpFlag.Changed {
			helpRequested = true
		}

		if !helpRequested {
			// Get actual arguments (handles DisableFlagParsing=true case).
			arguments := flags.GetActualArgs(command, os.Args)
			showUsageAndExit(command, arguments)
		}

		// Distinguish between interactive 'atmos help' and flag-based '--help':
		// - 'atmos help' (Contains "help" but NOT "--help" or "-h") → interactive, may use pager
		// - 'atmos --help' or 'atmos cmd --help' → simple output, NO pager unless --pager explicitly set
		isInteractiveHelp := Contains(os.Args, "help") && !Contains(os.Args, "--help") && !Contains(os.Args, "-h")
		isFlagHelp := Contains(os.Args, "--help") || Contains(os.Args, "-h")

		// Logo and version are now printed by customRenderAtmosHelp
		telemetry.PrintTelemetryDisclosure()

		// For flag-based help (--help), render directly to stdout without buffering or pager.
		// Only use pager if --pager flag is explicitly set.
		switch {
		case isFlagHelp:
			// Check if --pager flag was explicitly set.
			pagerExplicitlySet := false
			pagerEnabled := false
			if pagerFlag, err := command.Flags().GetString("pager"); err == nil && pagerFlag != "" {
				pagerExplicitlySet = true
				switch pagerFlag {
				case "true", "on", "yes", "1":
					pagerEnabled = true
				case "false", "off", "no", "0":
					pagerEnabled = false
				default:
					// Assume it's a pager command like "less" or "more".
					pagerEnabled = true
				}
			}

			if pagerExplicitlySet && pagerEnabled {
				// User explicitly requested pager for flag help.
				var buf bytes.Buffer
				command.SetOut(&buf)
				applyColoredHelpTemplate(command)
				_ = command.Help()
				pager := pager.NewWithAtmosConfig(true)
				_ = pager.Run("Atmos CLI Help", buf.String())
			} else {
				// Default: render help directly to stdout without pager.
				applyColoredHelpTemplate(command)
				_ = command.Help()
			}
		case isInteractiveHelp:
			// Interactive 'atmos help' command - use pager if configured.
			var buf bytes.Buffer
			command.SetOut(&buf)
			applyColoredHelpTemplate(command)
			_ = command.Help()

			// Check pager configuration from flag, env, or config.
			pagerEnabled := atmosConfig.Settings.Terminal.IsPagerEnabled()
			if pagerFlag, err := command.Flags().GetString("pager"); err == nil && pagerFlag != "" {
				switch pagerFlag {
				case "true", "on", "yes", "1":
					pagerEnabled = true
				case "false", "off", "no", "0":
					pagerEnabled = false
				default:
					pagerEnabled = true
				}
			}

			pager := pager.NewWithAtmosConfig(pagerEnabled)
			if err := pager.Run("Atmos CLI Help", buf.String()); err != nil {
				// Pager already falls back to direct output (pkg/pager/pager.go:88-92).
				// Just log a warning - help was still shown successfully.
				log.Warn("Pager unavailable, content printed directly", "error", err)
			}
		default:
			// Fallback for other cases.
			applyColoredHelpTemplate(command)
			_ = command.Help()
		}

		CheckForAtmosUpdateAndPrintMessage(atmosConfig)
	})
}

// https://www.sobyte.net/post/2021-12/create-cli-app-with-cobra/
// https://github.com/spf13/cobra/blob/master/user_guide.md
// https://blog.knoldus.com/create-kubectl-like-cli-with-go-and-cobra/
// https://pkg.go.dev/github.com/c-bata/go-prompt
// https://pkg.go.dev/github.com/spf13/cobra
// https://scene-si.org/2017/04/20/managing-configuration-with-viper/