#atmos-dev (2025-01)

package getter

import (
	"fmt"
	"net/url"
	"strings"
)

// GitHubDetector implements Detector to detect GitHub URLs and turn
// them into URLs that the Git Getter can understand.
type GitHubDetector struct{}

func (d *GitHubDetector) Detect(src, _ string) (string, bool, error) {
	if len(src) == 0 {
		return "", false, nil
	}

	if strings.HasPrefix(src, "github.com/") {
		return d.detectHTTP(src)
	}

	return "", false, nil
}

func (d *GitHubDetector) detectHTTP(src string) (string, bool, error) {
	parts := strings.Split(src, "/")
	if len(parts) < 3 {
		return "", false, fmt.Errorf(
			"GitHub URLs should be github.com/username/repo")
	}

	urlStr := fmt.Sprintf("https://%s", strings.Join(parts[:3], "/"))
	url, err := url.Parse(urlStr)
	if err != nil {
		return "", true, fmt.Errorf("error parsing GitHub URL: %s", err)
	}

	if !strings.HasSuffix(url.Path, ".git") {
		url.Path += ".git"
	}

	if len(parts) > 3 {
		url.Path += "//" + strings.Join(parts[3:], "/")
	}

	return "git::" + url.String(), true, nil
}

Getting updates for unmanaged Helm repositories...
...Unable to get an update from the "<https://charts.bitnami.com/bitnami>" chart repository:
	stream error: stream ID 1; INTERNAL_ERROR; received from peer

	if u.FileExists(atmosConfig.Schemas.Atmos.Manifest) {
		atmosManifestJsonSchemaFilePath = atmosConfig.Schemas.Atmos.Manifest
	} else if u.FileExists(atmosManifestJsonSchemaFileAbsPath) {
		atmosManifestJsonSchemaFilePath = atmosManifestJsonSchemaFileAbsPath
	} else if u.IsURL(atmosConfig.Schemas.Atmos.Manifest) {
		atmosManifestJsonSchemaFilePath, err = downloadSchemaFromURL(atmosConfig.Schemas.Atmos.Manifest)
		if err != nil {
			return err
		}
	} else {
		return fmt.Errorf("Schema file '%s' not found. Configure via:\n"+
			"1. 'schemas.atmos.manifest' in atmos.yaml\n"+
			"2. ATMOS_SCHEMAS_ATMOS_MANIFEST env var\n"+
			"3. --schemas-atmos-manifest flag\n\n"+
			"Accepts: absolute path, paths relative to base_path, or URL",
			atmosConfig.Schemas.Atmos.Manifest)
	}

B -- Yes --> C["Process Imports in Order"]
C --> D{"Import Type?"}
D --> E["Remote URL"]
D --> F["Specific Path"]
D --> G["Wildcard Globs"]

E --> H["Fetch Config from Remote URL"]
F --> I["Read Config from Filesystem"]
G --> I["Read Config from Filesystem"]

H --> J["Call Load Configuration File (Recursively)"]
I --> J["Call Load Configuration File (Recursively)"]

J --> L["Deep Merge with Current Config in Memory"]
L --> K{"More Imports to Process?"}
K -- Yes --> C
K -- No --> M["Configuration Processing Complete"]

%% Loopback for recursion
J -.-> A

%% Styling for clarity
style A fill<i class="em em-#A8DADC,stroke"></i>#1D3557,stroke-width<i class="em em-2px,color"></i>#000000
style B fill<i class="em em-#F4A261,stroke"></i>#1D3557,stroke-width<i class="em em-2px,color"></i>#FFFFFF
style C fill<i class="em em-#457B9D,stroke"></i>#1D3557,stroke-width<i class="em em-2px,color"></i>#FFFFFF
style D fill<i class="em em-#A8DADC,stroke"></i>#1D3557,stroke-width<i class="em em-2px,color"></i>#000000
style E fill<i class="em em-#E63946,stroke"></i>#1D3557,stroke-width<i class="em em-2px,color"></i>#FFFFFF
style F fill<i class="em em-#E63946,stroke"></i>#1D3557,stroke-width<i class="em em-2px,color"></i>#FFFFFF
style G fill<i class="em em-#E63946,stroke"></i>#1D3557,stroke-width<i class="em em-2px,color"></i>#FFFFFF
style H fill<i class="em em-#A8DADC,stroke"></i>#1D3557,stroke-width<i class="em em-2px,color"></i>#000000
style I fill<i class="em em-#A8DADC,stroke"></i>#1D3557,stroke-width<i class="em em-2px,color"></i>#000000
style J fill<i class="em em-#F4A261,stroke"></i>#1D3557,stroke-width<i class="em em-2px,color"></i>#FFFFFF
style L fill<i class="em em-#457B9D,stroke"></i>#1D3557,stroke-width<i class="em em-2px,color"></i>#FFFFFF
style K fill<i class="em em-#F4A261,stroke"></i>#1D3557,stroke-width<i class="em em-2px,color"></i>#FFFFFF
style M fill<i class="em em-#1D3557,stroke"></i>#1D3557,stroke-width<i class="em em-2px,color"></i>#FFFFFF

classDef recursion stroke-dasharray: 5 5;

%% If --config is provided
B -- Yes --> C["Stage 1: Load Explicit Configurations via --config"]
C --> C1{"Load each --config path in order"}
C1 --> C2["Update ATMOS_CLI_CONFIG_PATH with loaded config absolute paths (separated by delimiter)"]
C2 --> D["Process Imports and Deep Merge"]
D --> E["Final Merged Config"]
E --> F["Output Final Configuration"]

%% If --config is not provided
B -- No --> G["Stage 1: Load System Configurations"]
G --> G1{"Check System Paths"}
G1 -- Found --> G2["Load First Found Config: %PROGRAMDATA%/atmos.yaml (Windows), /usr/local/etc/atmos.yaml, or /etc/atmos.yaml"]
G2 --> G3["Update ATMOS_CLI_CONFIG_PATH"]
G3 --> H["Process Imports and Deep Merge"]
G1 -- Not Found --> H["Process Imports and Deep Merge"]

H --> I["Stage 2: Discover Additional Configurations"]
I --> I1{"Check ATMOS_CLI_CONFIG_PATH"}
I1 -- Found --> I2["Load First Found Config: atmos.yaml or atmos.d/**/* from ATMOS_CLI_CONFIG_PATH"]
I2 --> I4["Update ATMOS_CLI_CONFIG_PATH with loaded absolute paths"]
I4 --> J["Process Imports and Deep Merge"]
I1 -- Not Found --> I5{"Check Git Repository Root"}
I5 -- Found --> I6["Load First Found Config: atmos.yaml, .atmos.yaml, atmos.d/**/*, .atmos.d/**/*, or .github/atmos.yaml from Git Repo Root"]
I6 --> I4
I5 -- Not Found --> I12{"Check Current Working Directory"}

%% New branch for Current Working Directory (note it's not identical to repo root)
I12 -- Found --> I13["Load First Found Config: atmos.yaml, .atmos.yaml, atmos.d/**/*, .atmos.d/**/* from CWD"]
I13 --> I4
I12 -- Not Found --> I18["No configuration found in Stage 2"]
I18 --> K["Stage 3: Apply User Preferences"]

J --> K["Stage 3: Apply User Preferences"]
K --> K1{"Check $XDG_CONFIG_HOME/atmos.yaml"}
K1 -- Found --> K2["Load First Found Config: $XDG_CONFIG_HOME/atmos.yaml"]
K2 --> K3["Update ATMOS_CLI_CONFIG_PATH with $XDG_CONFIG_HOME/atmos.yaml"]
K3 --> L["Process Imports and Deep Merge"]
K1 -- Not Found --> K4{"Check User's Home Directory"}
K4 -- Found --> K5["Load First Found Config: %LOCALAPPDATA%/atmos/atmos.yaml (Windows), ~~~/.config/atmos/atmos.yaml, or ~~~atmos/atmos.yaml (Linux/macOS)"]
K5 --> K3
K4 -- Not Found --> K7["No configuration found in Stage 3"]
K7 --> M["Final Merged Config"]

L --> M["Final Merged Config"]
M --> F["Output Final Configuration"]

%% Styling for clarity
style A fill<i class="em em-#457B9D,stroke"></i>#1D3557,stroke-width<i class="em em-2px,color"></i>#FFFFFF
style Z1 fill<i class="em em-#A8DADC,stroke"></i>#1D3557,stroke-width<i class="em em-2px,color"></i>#000000
style Z2 fill<i class="em em-#A8DADC,stroke"></i>#1D3557,stroke-width<i class="em em-2px,color"></i>#000000
style Z3 fill<i class="em em-#E63946,stroke"></i>#1D3557,stroke-width<i class="em em-2px,color"></i>#FFFFFF
style B fill<i class="em em-#F4A261,stroke"></i>#1D3557,stroke-width<i class="em em-2px,color"></i>#FFFFFF
style C fill<i class="em em-#A8DADC,stroke"></i>#1D3557,stroke-width<i class="em em-2px,color"></i>#000000
style C1 fill<i class="em em-#A8DADC,stroke"></i>#1D3557,stroke-width<i class="em em-2px,color"></i>#000000
style C2 fill<i class="em em-#A8DADC,stroke"></i>#1D3557,stroke-width<i class="em em-2px,color"></i>#000000
style D fill<i class="em em-#E63946,stroke"></i>#1D3557,stroke-width<i class="em em-2px,color"></i>#FFFFFF
style E fill<i class="em em-#457B9D,stroke"></i>#1D3557,stroke-width<i class="em em-2px,color"></i>#FFFFFF
style F fill<i class="em em-#1D3557,stroke"></i>#1D3557,stroke-width<i class="em em-2px,color"></i>#FFFFFF
style G fill<i class="em em-#A8DADC,stroke"></i>#1D3557,stroke-width<i class="em em-2px,color"></i>#000000
style G1 fill<i class="em em-#F4A261,stroke"></i>#1D3557,stroke-width<i class="em em-2px,color"></i>#FFFFFF
style G2 fill<i class="em em-#E63946,stroke"></i>#1D3557,stroke-width<i class="em em-2px,color"></i>#FFFFFF
style G3 fill<i class="em em-#A8DADC,stroke"></i>#1D3557,stroke-width<i class="em em-2px,color"></i>#000000
style H fill<i class="em em-#E63946,stroke"></i>#1D3557,stroke-width<i class="em em-2px,color"></i>#FFFFFF
style I fill<i class="em em-#F4A261,stroke"></i>#1D3557,stroke-width<i class="em em-2px,color"></i>#FFFFFF
style I1 fill<i class="em em-#F4A261,stroke"></i>#1D3557,stroke-width<i class="em em-2px,color"></i>#FFFFFF
style I2 fill<i class="em em-#E63946,stroke"></i>#1D3557,stroke-width<i class="em em-2px,color"></i>#FFFFFF
style I4 fill<i class="em em-#A8DADC,stroke"></i>#1D3557,stroke-width<i class="em em-2px,color"></i>#000000
style J fill<i class="em em-#E63946,stroke"></i>#1D3557,stroke-width<i class="em em-2px,color"></i>#FFFFFF
style I5 fill<i class="em em-#F4A261,stroke"></i>#1D3557,stroke-width<i class="em em-2px,color"></i>#FFFFFF
style I6 fill<i class="em em-#E63946,stroke"></i>#1D3557,stroke-width<i class="em em-2px,color"></i>#FFFFFF
style I12 fill<i class="em em-#F4A261,stroke"></i>#1D3557,stroke-width<i class="em em-2px,color"></i>#FFFFFF
style I13 fill<i class="em em-#E63946,stroke"></i>#1D3557,stroke-width<i class="em em-2px,color"></i>#FFFFFF
style I18 fill<i class="em em-#A8DADC,stroke"></i>#1D3557,stroke-width<i class="em em-2px,color"></i>#000000
style K fill<i class="em em-#F4A261,stroke"></i>#1D3557,stroke-width<i class="em em-2px,color"></i>#FFFFFF
style K1 fill<i class="em em-#F4A261,stroke"></i>#1D3557,stroke-width<i class="em em-2px,color"></i>#FFFFFF
style K2 fill<i class="em em-#E63946,stroke"></i>#1D3557,stroke-width<i class="em em-2px,color"></i>#FFFFFF
style K3 fill<i class="em em-#A8DADC,stroke"></i>#1D3557,stroke-width<i class="em em-2px,color"></i>#000000
style K4 fill<i class="em em-#F4A261,stroke"></i>#1D3557,stroke-width<i class="em em-2px,color"></i>#FFFFFF
style K5 f…

"github.com/pkg/errors"
"github.com/spf13/cobra"

tuiUtils "github.com/cloudposse/atmos/internal/tui/utils"
cfg "github.com/cloudposse/atmos/pkg/config"
"github.com/cloudposse/atmos/pkg/schema"
u "github.com/cloudposse/atmos/pkg/utils" )

if info.SubCommand == "clean" &&
	(u.SliceContainsString(info.AdditionalArgsAndFlags, everythingFlag) ||
		u.SliceContainsString(info.AdditionalArgsAndFlags, forceFlag)) {
	if info.ComponentFromArg == "" {
		shouldProcessStacks = false
	}

	shouldCheckStack = info.Stack != ""

}

return shouldProcessStacks, shouldCheckStack }

	u.LogDebug(*atmosConfig, "\nWriting the backend config to file:")
	u.LogDebug(*atmosConfig, backendFileName)

	if !info.DryRun {
		componentBackendConfig, err := generateComponentBackendConfig(info.ComponentBackendType, info.ComponentBackendSection, info.TerraformWorkspace)
		if err != nil {
			return err
		}

		err = u.WriteToFileAsJSON(backendFileName, componentBackendConfig, 0644)
		if err != nil {
			return err
		}
	}
}

return nil }

	u.LogDebug(*atmosConfig, "\nWriting the provider overrides to file:")
	u.LogDebug(*atmosConfig, providerOverrideFileName)

	if !info.DryRun {
		var providerOverrides = generateComponentProviderOverrides(info.ComponentProvidersSection)
		err := u.WriteToFileAsJSON(providerOverrideFileName, providerOverrides, 0644)
		return err
	}
}
return nil }

if info.NeedHelp {
	return nil
}

// If the user just types `atmos terraform`, print Atmos logo and show terraform help
if info.SubCommand == "" {
	fmt.Println()
	err = tuiUtils.PrintStyledText("ATMOS")
	if err != nil {
		return err
	}

	err = processHelp(atmosConfig, "terraform", "")
	if err != nil {
		return err
	}

	fmt.Println()
	return nil
}

if info.SubCommand == "version" {
	return ExecuteShellCommand(atmosConfig,
		"terraform",
		[]string{info.SubCommand},
		"",
		nil,
		false,
		info.RedirectStdErr)
}

// Skip stack processing when cleaning with --everything or --force flags to allow cleaning without requiring stack
// configuration
shouldProcessStacks, shouldCheckStack := shouldProcessStacks(&info)

if shouldProcessStacks {
	info, err = ProcessStacks(atmosConfig, info, shouldCheckStack, true)
	if err != nil {
		return err
	}

	if len(info.Stack) < 1 && shouldCheckStack {
		return errors.New("stack must be specified when not using --everything or --force flags")
	}
}

if !info.ComponentIsEnabled {
	u.LogInfo(atmosConfig, fmt.Sprintf("component '%s' is not enabled and skipped", info.ComponentFromArg))
	return nil
}

err = checkTerraformConfig(atmosConfig)
if err != nil {
	return err
}

// Check if the component (or base component) exists as Terraform component
componentPath := filepath.Join(atmosConfig.TerraformDirAbsolutePath, info.ComponentFolderPrefix, info.FinalComponent)
componentPathExists, err := u.IsDirectory(componentPath)
if err != nil || !componentPathExists {
	return fmt.Errorf("'%s' points to the Terraform component '%s', but it does not exist in '%s'",
		info.ComponentFromArg,
		info.FinalComponent,
		filepath.Join(atmosConfig.Components.Terraform.BasePath, info.ComponentFolderPrefix),
	)
}

// Check if the component is allowed to be provisioned (`metadata.type` attribute is not set to `abstract`)
if (info.SubCommand == "plan" || info.SubCommand == "apply" || info.SubCommand == "deploy" || info.SubCommand == "workspace") && info.ComponentIsAbstract {
	return fmt.Errorf("abstract component '%s' cannot be provisioned since it's explicitly prohibited from being deployed "+
		"by 'metadata.type: abstract' attribute", filepath.Join(info.ComponentFolderPrefix, info.Component))
}

// Check if the component is locked (`metadata.locked` is set to true)
if info.ComponentIsLocked {
	// Allow read-only commands, block modification commands
	switch info.SubCommand {
	case "apply", "deploy", "destroy", "import", "state", "taint", "untaint":
		return fmt.Errorf("component '%s' is locked and cannot be modified (metadata.locked = true)",
			filepath.Join(info.ComponentFolderPrefix, info.Component))
	}
}

if info.SubCommand == "clean" {
	err := handleCleanSubCommand(info, componentPath, atmosConfig)
	if err != nil {
		u.LogTrace(atmosConfig, fmt.Errorf("error cleaning the terraform component: %v", err).Error())
		return err
	}
	return nil
}

varFile := constructTerraformComponentVarfileName(info)
planFile := constructTerraformComponentPlanfileName(info)

// Print component variables and write to file
// Don't process variables when executing `terraform workspace` commands
if info.SubCommand != "workspace" {
	u.LogDebug(atmosConfig, fmt.Sprintf("\nVariables for the component '%s' in the stack '%s':", info.ComponentFromArg, info.Stack))

	if atmosConfig.Logs.Level == u.LogLevelTrace || atmosConfig.Logs.Level == u.LogLevelDebug {
		err = u.PrintAsYAMLToFileDescriptor(atmosConfig, info.ComponentVarsSection)
		if err != nil {
			return err
		}
	}

	// Write variables to a file (only if we are not using the previously generated terraform plan)
	if !info.UseTerraformPlan {
		var varFilePath, varFileNameFromArg string

		// Handle `terraform varfile` and `terraform write varfile` legacy commands
		if info.SubCommand == "varfile" || (info.SubCommand == "write" && info.SubCommand2 == "varfile") {
			if len(info.AdditionalArgsAndFlags) == 2 {
				fileFlag := info.AdditionalArgsAndFlags[0]
				if fileFlag == "-f" || fileFlag == "--file" {
					varFileNameFromArg = info.AdditionalArgsAndFlags[1]
				}
			}
		}

		if len(varFileNameFromArg) > 0 {
			varFilePath = varFileNameFromArg
		} else {
			varFilePath = constructTerraformComponentVarfilePath(atmosConfig, info)
		}

		u.LogDebug(atmosConfig, "Writing the variables to file:")
		u.LogDebug(atmosConfig, varFilePath)

		if !info.DryRun {
			err = u.WriteToFileAsJSON(varFilePath, info.ComponentVarsSection, 0644)
			if err != nil {
				return err
			}
		}
	}
}

// Handle `terraform varfile` and `terraform write varfile` legacy comm…