Git-Mirrors/constellation
1
0
Fork 0
mirror of https://github.com/edgelesssys/constellation.git synced 2025-04-09 17:39:06 -04:00
Code Issues Packages Projects Releases Wiki Activity

Terraform: Make variables writing retryable

Browse Source
This commit is contained in:
Nils Hanke 2022-11-15 11:18:52 +01:00 committed by Nils Hanke
parent e93527144e
commit f27af5b588
1 changed files with 25 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

27
cli/internal/terraform/terraform.go
View File

@ -65,11 +65,11 @@ func (c *Client) CreateCluster(
return "", err
}
if err := c.tf.Init(ctx); err != nil {
if err := c.writeVars(vars); err != nil {
return "", err
}
if err := c.file.Write(filepath.Join(c.workingDir, terraformVarsFile), []byte(vars.String())); err != nil {
if err := c.tf.Init(ctx); err != nil {
return "", err
}
@ -142,6 +142,29 @@ func GetExecutable(ctx context.Context, workingDir string) (terraform *tfexec.Te
return tf, func() { _ = inst.Remove(context.Background()) }, err
}
// writeVars tries to write the Terraform variables file or, if it exists, checks if it is the same as we are expecting.
func (c *Client) writeVars(vars Variables) error {
if vars == nil {
return errors.New("creating cluster: vars is nil")
}
pathToVarsFile := filepath.Join(c.workingDir, terraformVarsFile)
if err := c.file.Write(pathToVarsFile, []byte(vars.String())); errors.Is(err, afero.ErrFileExists) {
// If a variables file already exists, check if it's the same as we're expecting, so we can continue using it.
varsContent, err := c.file.Read(pathToVarsFile)
if err != nil {
return err
}
if vars.String() != string(varsContent) {
return errors.New("creating cluster: workspace already exists with different variables")
}
} else if err != nil {
return err
}
return nil
}
type tfInterface interface {
Apply(context.Context, ...tfexec.ApplyOption) error
Destroy(context.Context, ...tfexec.DestroyOption) error