-
-
Notifications
You must be signed in to change notification settings - Fork 1
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Add support for resource gocd_environment
- Loading branch information
1 parent
faae241
commit 04e6ba4
Showing
11 changed files
with
298 additions
and
20 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,20 @@ | ||
| resource "gocd_environment" "sample_environment" { | ||
| name = "sample_environment" | ||
| pipelines = [ | ||
| "gocd-prometheus-exporter", | ||
| "helm-images", | ||
| "action-movies-manual", | ||
| ] | ||
| environment_variables { | ||
| name = "TEST_ENV11" | ||
| value = "value_env11" | ||
| } | ||
| environment_variables { | ||
| name = "TEST_ENV12" | ||
| value = "value_env18" | ||
| } | ||
| environment_variables { | ||
| name = "TEST_ENV13" | ||
| value = "value_env13" | ||
| } | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,218 @@ | ||
| package gocd | ||
|
|
||
| import ( | ||
| "context" | ||
| "fmt" | ||
| "log" | ||
|
|
||
| "github.com/google/go-cmp/cmp" | ||
| "github.com/hashicorp/terraform-plugin-sdk/v2/diag" | ||
| "github.com/hashicorp/terraform-plugin-sdk/v2/helper/schema" | ||
| "github.com/mitchellh/mapstructure" | ||
| "github.com/nikhilsbhat/gocd-sdk-go" | ||
| "github.com/nikhilsbhat/terraform-provider-gocd/pkg/utils" | ||
| ) | ||
|
|
||
| func resourceEnvironment() *schema.Resource { | ||
| return &schema.Resource{ | ||
| CreateContext: resourceEnvironmentCreate, | ||
| ReadContext: resourceEnvironmentRead, | ||
| DeleteContext: resourceEnvironmentDelete, | ||
| UpdateContext: resourceEnvironmentUpdate, | ||
| Schema: map[string]*schema.Schema{ | ||
| "name": { | ||
| Type: schema.TypeString, | ||
| Required: true, | ||
| Computed: false, | ||
| ForceNew: true, | ||
| Description: "The name of environment.", | ||
| }, | ||
| "pipelines": { | ||
| Type: schema.TypeList, | ||
| Optional: true, | ||
| Computed: false, | ||
| Description: "List of pipeline names that should be added to this environment.", | ||
| Elem: &schema.Schema{Type: schema.TypeString}, | ||
| }, | ||
| //"metadata": { | ||
| // Type: schema.TypeMap, | ||
| // Optional: true, | ||
| // Computed: false, | ||
| // Description: "Dummy type to handle updates", | ||
| // Elem: &schema.Schema{ | ||
| // Type: schema.TypeString, | ||
| // }, | ||
| //}, | ||
| "environment_variables": environmentsSchema(), | ||
| "etag": { | ||
| Type: schema.TypeString, | ||
| Required: false, | ||
| Computed: true, | ||
| ForceNew: false, | ||
| Description: "etag used to track the plugin settings", | ||
| }, | ||
| }, | ||
| } | ||
| } | ||
|
|
||
| type environmentChanges struct { | ||
| envVarsChanges []gocd.EnvVars | ||
| pipelineChanges []gocd.Pipeline | ||
| equal bool | ||
| } | ||
|
|
||
| func resourceEnvironmentCreate(ctx context.Context, d *schema.ResourceData, meta interface{}) diag.Diagnostics { | ||
| defaultConfig := meta.(gocd.GoCd) | ||
|
|
||
| if !d.IsNewResource() { | ||
| return nil | ||
| } | ||
| id := d.Id() | ||
|
|
||
| if len(id) == 0 { | ||
| newID, err := utils.GetRandomID() | ||
| if err != nil { | ||
| d.SetId("") | ||
|
|
||
| return diag.Errorf("errored while fetching randomID %v", err) | ||
| } | ||
| id = newID | ||
| } | ||
|
|
||
| envVars, err := getEnvironments(d.Get(utils.TerraformEnvVar)) | ||
| if err != nil { | ||
| return diag.Errorf("reading environment errored with %v", err) | ||
| } | ||
|
|
||
| cfg := gocd.Environment{ | ||
| Name: utils.String(d.Get(utils.TerraformResourceName)), | ||
| Pipelines: getPipelines(d.Get(utils.TerraformPipelines)), | ||
| EnvVars: envVars, | ||
| } | ||
|
|
||
| if err = defaultConfig.CreateEnvironment(cfg); err != nil { | ||
| return diag.Errorf("creating environment %s errored with %v", cfg.Name, err) | ||
| } | ||
|
|
||
| d.SetId(id) | ||
|
|
||
| return resourceEnvironmentRead(ctx, d, meta) | ||
| } | ||
|
|
||
| func resourceEnvironmentRead(ctx context.Context, d *schema.ResourceData, meta interface{}) diag.Diagnostics { | ||
| defaultConfig := meta.(gocd.GoCd) | ||
|
|
||
| envName := utils.String(d.Get(utils.TerraformResourceName)) | ||
| response, err := defaultConfig.GetEnvironment(envName) | ||
| if err != nil { | ||
| return diag.Errorf("getting environment %s errored with: %v", envName, err) | ||
| } | ||
|
|
||
| if err = d.Set(utils.TerraformResourceEtag, response.ETAG); err != nil { | ||
| return diag.Errorf("setting etag errored with %v", err) | ||
| } | ||
|
|
||
| return nil | ||
| } | ||
|
|
||
| func resourceEnvironmentUpdate(ctx context.Context, d *schema.ResourceData, meta interface{}) diag.Diagnostics { | ||
| defaultConfig := meta.(gocd.GoCd) | ||
|
|
||
| if d.HasChange(utils.TerraformPipelines) || d.HasChange(utils.TerraformEnvVar) { | ||
| changes, err := getEnvChanges(d) | ||
| if err != nil { | ||
| return diag.Errorf("fetching changes errored with %v", err) | ||
| } | ||
|
|
||
| if changes.equal { | ||
| return nil | ||
| } | ||
|
|
||
| cfg := gocd.Environment{ | ||
| Name: utils.String(d.Get(utils.TerraformResourceName)), | ||
| Pipelines: changes.pipelineChanges, | ||
| EnvVars: changes.envVarsChanges, | ||
| ETAG: utils.String(d.Get(utils.TerraformResourceEtag)), | ||
| } | ||
|
|
||
| _, err = defaultConfig.UpdateEnvironment(cfg) | ||
| if err != nil { | ||
| return diag.Errorf("updating environment %s errored with: %v", cfg.Name, err) | ||
| } | ||
|
|
||
| return resourceEnvironmentRead(ctx, d, meta) | ||
| } | ||
|
|
||
| log.Printf("nothing to update so skipping") | ||
|
|
||
| return nil | ||
| } | ||
|
|
||
| func resourceEnvironmentDelete(ctx context.Context, d *schema.ResourceData, meta interface{}) diag.Diagnostics { | ||
| defaultConfig := meta.(gocd.GoCd) | ||
|
|
||
| if id := d.Id(); len(id) == 0 { | ||
| return diag.Errorf("resource with the ID '%s' not found", id) | ||
| } | ||
|
|
||
| envName := utils.String(d.Get(utils.TerraformResourceName)) | ||
|
|
||
| err := defaultConfig.DeleteEnvironment(envName) | ||
| if err != nil { | ||
| return diag.Errorf("deleting environment %s errored with: %v", envName, err) | ||
| } | ||
|
|
||
| d.SetId("") | ||
|
|
||
| return nil | ||
| } | ||
|
|
||
| func getEnvironments(configs interface{}) ([]gocd.EnvVars, error) { | ||
| var envVars []gocd.EnvVars | ||
| envs := configs.(*schema.Set).List() | ||
| if err := mapstructure.Decode(envs, &envVars); err != nil { | ||
| return nil, fmt.Errorf(err.Error()) | ||
| } | ||
|
|
||
| return envVars, nil | ||
| } | ||
|
|
||
| func getPipelines(configs interface{}) []gocd.Pipeline { | ||
| pipelines := make([]gocd.Pipeline, 0) | ||
| for _, pipeline := range configs.([]interface{}) { | ||
| pipelines = append(pipelines, gocd.Pipeline{Name: utils.String(pipeline)}) | ||
| } | ||
|
|
||
| return pipelines | ||
| } | ||
|
|
||
| func getEnvChanges(d *schema.ResourceData) (environmentChanges, error) { | ||
| var changes environmentChanges | ||
| oldVars, newVars := d.GetChange(utils.TerraformEnvVar) | ||
| oldPipelines, newPipelines := d.GetChange(utils.TerraformPipelines) | ||
|
|
||
| envVars, err := getEnvironments(oldVars) | ||
| if err != nil { | ||
| return changes, fmt.Errorf("reading environment errored with %v", err) | ||
| } | ||
|
|
||
| changes.equal = true | ||
| changes.envVarsChanges = envVars | ||
| changes.pipelineChanges = getPipelines(oldPipelines) | ||
|
|
||
| if !cmp.Equal(oldVars, newVars) { | ||
| envVars, err = getEnvironments(newVars) | ||
| if err != nil { | ||
| return changes, fmt.Errorf("reading environment errored with %v", err) | ||
| } | ||
| changes.envVarsChanges = envVars | ||
| changes.equal = false | ||
| } | ||
|
|
||
| if !cmp.Equal(oldPipelines, newPipelines) { | ||
| changes.pipelineChanges = getPipelines(newPipelines) | ||
| changes.equal = false | ||
| } | ||
|
|
||
| return changes, nil | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.