| // simple provider a minimal provider implementation for testing |
| package simple |
| |
| import ( |
| "errors" |
| "time" |
| |
| "github.com/hashicorp/terraform/internal/configs/configschema" |
| "github.com/hashicorp/terraform/internal/providers" |
| "github.com/zclconf/go-cty/cty" |
| ctyjson "github.com/zclconf/go-cty/cty/json" |
| ) |
| |
| type simple struct { |
| schema providers.GetProviderSchemaResponse |
| } |
| |
| func Provider() providers.Interface { |
| simpleResource := providers.Schema{ |
| Block: &configschema.Block{ |
| Attributes: map[string]*configschema.Attribute{ |
| "id": { |
| Computed: true, |
| Type: cty.String, |
| }, |
| "value": { |
| Optional: true, |
| Type: cty.String, |
| }, |
| }, |
| }, |
| } |
| |
| return simple{ |
| schema: providers.GetProviderSchemaResponse{ |
| Provider: providers.Schema{ |
| Block: nil, |
| }, |
| ResourceTypes: map[string]providers.Schema{ |
| "simple_resource": simpleResource, |
| }, |
| DataSources: map[string]providers.Schema{ |
| "simple_resource": simpleResource, |
| }, |
| ServerCapabilities: providers.ServerCapabilities{ |
| PlanDestroy: true, |
| }, |
| }, |
| } |
| } |
| |
| func (s simple) GetProviderSchema() providers.GetProviderSchemaResponse { |
| return s.schema |
| } |
| |
| func (s simple) ValidateProviderConfig(req providers.ValidateProviderConfigRequest) (resp providers.ValidateProviderConfigResponse) { |
| return resp |
| } |
| |
| func (s simple) ValidateResourceConfig(req providers.ValidateResourceConfigRequest) (resp providers.ValidateResourceConfigResponse) { |
| return resp |
| } |
| |
| func (s simple) ValidateDataResourceConfig(req providers.ValidateDataResourceConfigRequest) (resp providers.ValidateDataResourceConfigResponse) { |
| return resp |
| } |
| |
| func (p simple) UpgradeResourceState(req providers.UpgradeResourceStateRequest) (resp providers.UpgradeResourceStateResponse) { |
| ty := p.schema.ResourceTypes[req.TypeName].Block.ImpliedType() |
| val, err := ctyjson.Unmarshal(req.RawStateJSON, ty) |
| resp.Diagnostics = resp.Diagnostics.Append(err) |
| resp.UpgradedState = val |
| return resp |
| } |
| |
| func (s simple) ConfigureProvider(providers.ConfigureProviderRequest) (resp providers.ConfigureProviderResponse) { |
| return resp |
| } |
| |
| func (s simple) Stop() error { |
| return nil |
| } |
| |
| func (s simple) ReadResource(req providers.ReadResourceRequest) (resp providers.ReadResourceResponse) { |
| // just return the same state we received |
| resp.NewState = req.PriorState |
| return resp |
| } |
| |
| func (s simple) PlanResourceChange(req providers.PlanResourceChangeRequest) (resp providers.PlanResourceChangeResponse) { |
| if req.ProposedNewState.IsNull() { |
| // destroy op |
| resp.PlannedState = req.ProposedNewState |
| resp.PlannedPrivate = req.PriorPrivate |
| return resp |
| } |
| |
| m := req.ProposedNewState.AsValueMap() |
| _, ok := m["id"] |
| if !ok { |
| m["id"] = cty.UnknownVal(cty.String) |
| } |
| |
| resp.PlannedState = cty.ObjectVal(m) |
| return resp |
| } |
| |
| func (s simple) ApplyResourceChange(req providers.ApplyResourceChangeRequest) (resp providers.ApplyResourceChangeResponse) { |
| if req.PlannedState.IsNull() { |
| resp.NewState = req.PlannedState |
| return resp |
| } |
| |
| m := req.PlannedState.AsValueMap() |
| _, ok := m["id"] |
| if !ok { |
| m["id"] = cty.StringVal(time.Now().String()) |
| } |
| resp.NewState = cty.ObjectVal(m) |
| |
| return resp |
| } |
| |
| func (s simple) ImportResourceState(providers.ImportResourceStateRequest) (resp providers.ImportResourceStateResponse) { |
| resp.Diagnostics = resp.Diagnostics.Append(errors.New("unsupported")) |
| return resp |
| } |
| |
| func (s simple) ReadDataSource(req providers.ReadDataSourceRequest) (resp providers.ReadDataSourceResponse) { |
| m := req.Config.AsValueMap() |
| m["id"] = cty.StringVal("static_id") |
| resp.State = cty.ObjectVal(m) |
| return resp |
| } |
| |
| func (s simple) Close() error { |
| return nil |
| } |