-
Notifications
You must be signed in to change notification settings - Fork 9.5k
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Merge pull request #31757 from hashicorp/jbardin/terraform-data
New `terraform_data` managed resource to replace `null_resource`
- Loading branch information
Showing
5 changed files
with
599 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
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,146 @@ | ||
| package terraform | ||
|
|
||
| import ( | ||
| "fmt" | ||
|
|
||
| "github.com/hashicorp/go-uuid" | ||
| "github.com/hashicorp/terraform/internal/configs/configschema" | ||
| "github.com/hashicorp/terraform/internal/providers" | ||
| "github.com/hashicorp/terraform/internal/tfdiags" | ||
| "github.com/zclconf/go-cty/cty" | ||
| ctyjson "github.com/zclconf/go-cty/cty/json" | ||
| ) | ||
|
|
||
| func dataStoreResourceSchema() providers.Schema { | ||
| return providers.Schema{ | ||
| Block: &configschema.Block{ | ||
| Attributes: map[string]*configschema.Attribute{ | ||
| "input": {Type: cty.DynamicPseudoType, Optional: true}, | ||
| "output": {Type: cty.DynamicPseudoType, Computed: true}, | ||
| "triggers_replace": {Type: cty.DynamicPseudoType, Optional: true}, | ||
| "id": {Type: cty.String, Computed: true}, | ||
| }, | ||
| }, | ||
| } | ||
| } | ||
|
|
||
| func validateDataStoreResourceConfig(req providers.ValidateResourceConfigRequest) (resp providers.ValidateResourceConfigResponse) { | ||
| if req.Config.IsNull() { | ||
| return resp | ||
| } | ||
|
|
||
| // Core does not currently validate computed values are not set in the | ||
| // configuration. | ||
| for _, attr := range []string{"id", "output"} { | ||
| if !req.Config.GetAttr(attr).IsNull() { | ||
| resp.Diagnostics = resp.Diagnostics.Append(fmt.Errorf(`%q attribute is read-only`, attr)) | ||
| } | ||
| } | ||
| return resp | ||
| } | ||
|
|
||
| func upgradeDataStoreResourceState(req providers.UpgradeResourceStateRequest) (resp providers.UpgradeResourceStateResponse) { | ||
| ty := dataStoreResourceSchema().Block.ImpliedType() | ||
| val, err := ctyjson.Unmarshal(req.RawStateJSON, ty) | ||
| if err != nil { | ||
| resp.Diagnostics = resp.Diagnostics.Append(err) | ||
| return resp | ||
| } | ||
|
|
||
| resp.UpgradedState = val | ||
| return resp | ||
| } | ||
|
|
||
| func readDataStoreResourceState(req providers.ReadResourceRequest) (resp providers.ReadResourceResponse) { | ||
| resp.NewState = req.PriorState | ||
| return resp | ||
| } | ||
|
|
||
| func planDataStoreResourceChange(req providers.PlanResourceChangeRequest) (resp providers.PlanResourceChangeResponse) { | ||
| if req.ProposedNewState.IsNull() { | ||
| // destroy op | ||
| resp.PlannedState = req.ProposedNewState | ||
| return resp | ||
| } | ||
|
|
||
| planned := req.ProposedNewState.AsValueMap() | ||
|
|
||
| input := req.ProposedNewState.GetAttr("input") | ||
| trigger := req.ProposedNewState.GetAttr("triggers_replace") | ||
|
|
||
| switch { | ||
| case req.PriorState.IsNull(): | ||
| // Create | ||
| // Set the id value to unknown. | ||
| planned["id"] = cty.UnknownVal(cty.String) | ||
|
|
||
| // Only compute a new output if input has a non-null value. | ||
| if !input.IsNull() { | ||
| planned["output"] = cty.UnknownVal(input.Type()) | ||
| } | ||
|
|
||
| resp.PlannedState = cty.ObjectVal(planned) | ||
| return resp | ||
|
|
||
| case !req.PriorState.GetAttr("triggers_replace").RawEquals(trigger): | ||
| // trigger changed, so we need to replace the entire instance | ||
| resp.RequiresReplace = append(resp.RequiresReplace, cty.GetAttrPath("triggers_replace")) | ||
| planned["id"] = cty.UnknownVal(cty.String) | ||
|
|
||
| // We need to check the input for the replacement instance to compute a | ||
| // new output. | ||
| if input.IsNull() { | ||
| planned["output"] = cty.NullVal(cty.DynamicPseudoType) | ||
| } else { | ||
| planned["output"] = cty.UnknownVal(input.Type()) | ||
| } | ||
|
|
||
| case !req.PriorState.GetAttr("input").RawEquals(input): | ||
| // only input changed, so we only need to re-compute output | ||
| planned["output"] = cty.UnknownVal(input.Type()) | ||
| } | ||
|
|
||
| resp.PlannedState = cty.ObjectVal(planned) | ||
| return resp | ||
| } | ||
|
|
||
| var testUUIDHook func() string | ||
|
|
||
| func applyDataStoreResourceChange(req providers.ApplyResourceChangeRequest) (resp providers.ApplyResourceChangeResponse) { | ||
| if req.PlannedState.IsNull() { | ||
| resp.NewState = req.PlannedState | ||
| return resp | ||
| } | ||
|
|
||
| newState := req.PlannedState.AsValueMap() | ||
|
|
||
| if !req.PlannedState.GetAttr("output").IsKnown() { | ||
| newState["output"] = req.PlannedState.GetAttr("input") | ||
| } | ||
|
|
||
| if !req.PlannedState.GetAttr("id").IsKnown() { | ||
| idString, err := uuid.GenerateUUID() | ||
| // Terraform would probably never get this far without a good random | ||
| // source, but catch the error anyway. | ||
| if err != nil { | ||
| diag := tfdiags.AttributeValue( | ||
| tfdiags.Error, | ||
| "Error generating id", | ||
| err.Error(), | ||
| cty.GetAttrPath("id"), | ||
| ) | ||
|
|
||
| resp.Diagnostics = resp.Diagnostics.Append(diag) | ||
| } | ||
|
|
||
| if testUUIDHook != nil { | ||
| idString = testUUIDHook() | ||
| } | ||
|
|
||
| newState["id"] = cty.StringVal(idString) | ||
| } | ||
|
|
||
| resp.NewState = cty.ObjectVal(newState) | ||
|
|
||
| return resp | ||
| } |
Oops, something went wrong.