ResiLien
/
terraform
2
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity
terraform/internal/grpcwrap/provider.go

416 lines
13 KiB
Go
Raw Permalink Normal View History

grpcwrap: convert provider interface to grpcserver grpcwrap wraps a core providers.Interface and converts it to a tfplugin5.ProviderServer to allow for easier protocol testing.
2020-11-20 00:34:58 +01:00
package grpcwrap
import (
"context"
Move plugin/ and plugin6/ to internal/plugin{,6}/ This is part of a general effort to move all of Terraform's non-library package surface under internal in order to reinforce that these are for internal use within Terraform only. If you were previously importing packages under this prefix into an external codebase, you could pin to an earlier release tag as an interim solution until you've make a plan to achieve the same functionality some other way.
2021-05-17 21:35:22 +02:00
"github.com/hashicorp/terraform/internal/plugin/convert"
Move providers/ to internal/providers/ This is part of a general effort to move all of Terraform's non-library package surface under internal in order to reinforce that these are for internal use within Terraform only. If you were previously importing packages under this prefix into an external codebase, you could pin to an earlier release tag as an interim solution until you've make a plan to achieve the same functionality some other way.
2021-05-17 19:40:40 +02:00
"github.com/hashicorp/terraform/internal/providers"
grpcwrap: convert provider interface to grpcserver grpcwrap wraps a core providers.Interface and converts it to a tfplugin5.ProviderServer to allow for easier protocol testing.
2020-11-20 00:34:58 +01:00
"github.com/hashicorp/terraform/internal/tfplugin5"
"github.com/zclconf/go-cty/cty"
ctyjson "github.com/zclconf/go-cty/cty/json"
"github.com/zclconf/go-cty/cty/msgpack"
)
// New wraps a providers.Interface to implement a grpc ProviderServer.
// This is useful for creating a test binary out of an internal provider
// implementation.
add grpcwrap.Provisioner Rename grpcwrap.New() to grpcwrap.Provider() Add a grpcwrap function to create a test proivisioner plugin.
2020-11-26 00:02:21 +01:00
func Provider(p providers.Interface) tfplugin5.ProviderServer {
return &provider{
grpcwrap: convert provider interface to grpcserver grpcwrap wraps a core providers.Interface and converts it to a tfplugin5.ProviderServer to allow for easier protocol testing.
2020-11-20 00:34:58 +01:00
provider: p,
Mildwonkey/providers interface renaming (#27805) * providers.Interface: huge renamification This commit renames a handful of functions in the providers.Interface to match changes made in protocol v6. The following commit implements this change across the rest of the codebase; I put this in a separate commit for ease of reviewing and will squash these together when merging. One noteworthy detail: protocol v6 removes the config from the ValidateProviderConfigResponse, since it's never been used. I chose to leave that in place in the interface until we deprecate support for protocol v5 entirely. Note that none of these changes impact current providers using protocol v5; the protocol is unchanged. Only the translation layer between the proto and terraform have changed.
2021-02-18 16:13:43 +01:00
schema: p.GetProviderSchema(),
grpcwrap: convert provider interface to grpcserver grpcwrap wraps a core providers.Interface and converts it to a tfplugin5.ProviderServer to allow for easier protocol testing.
2020-11-20 00:34:58 +01:00
}
}
add grpcwrap.Provisioner Rename grpcwrap.New() to grpcwrap.Provider() Add a grpcwrap function to create a test proivisioner plugin.
2020-11-26 00:02:21 +01:00
type provider struct {
grpcwrap: convert provider interface to grpcserver grpcwrap wraps a core providers.Interface and converts it to a tfplugin5.ProviderServer to allow for easier protocol testing.
2020-11-20 00:34:58 +01:00
provider providers.Interface
Mildwonkey/providers interface renaming (#27805) * providers.Interface: huge renamification This commit renames a handful of functions in the providers.Interface to match changes made in protocol v6. The following commit implements this change across the rest of the codebase; I put this in a separate commit for ease of reviewing and will squash these together when merging. One noteworthy detail: protocol v6 removes the config from the ValidateProviderConfigResponse, since it's never been used. I chose to leave that in place in the interface until we deprecate support for protocol v5 entirely. Note that none of these changes impact current providers using protocol v5; the protocol is unchanged. Only the translation layer between the proto and terraform have changed.
2021-02-18 16:13:43 +01:00
schema providers.GetProviderSchemaResponse
grpcwrap: convert provider interface to grpcserver grpcwrap wraps a core providers.Interface and converts it to a tfplugin5.ProviderServer to allow for easier protocol testing.
2020-11-20 00:34:58 +01:00
}
add grpcwrap.Provisioner Rename grpcwrap.New() to grpcwrap.Provider() Add a grpcwrap function to create a test proivisioner plugin.
2020-11-26 00:02:21 +01:00
func (p *provider) GetSchema(_ context.Context, req *tfplugin5.GetProviderSchema_Request) (*tfplugin5.GetProviderSchema_Response, error) {
grpcwrap: convert provider interface to grpcserver grpcwrap wraps a core providers.Interface and converts it to a tfplugin5.ProviderServer to allow for easier protocol testing.
2020-11-20 00:34:58 +01:00
resp := &tfplugin5.GetProviderSchema_Response{
ResourceSchemas: make(map[string]*tfplugin5.Schema),
DataSourceSchemas: make(map[string]*tfplugin5.Schema),
}
resp.Provider = &tfplugin5.Schema{
Block: &tfplugin5.Schema_Block{},
}
add grpcwrap.Provisioner Rename grpcwrap.New() to grpcwrap.Provider() Add a grpcwrap function to create a test proivisioner plugin.
2020-11-26 00:02:21 +01:00
if p.schema.Provider.Block != nil {
resp.Provider.Block = convert.ConfigSchemaToProto(p.schema.Provider.Block)
grpcwrap: convert provider interface to grpcserver grpcwrap wraps a core providers.Interface and converts it to a tfplugin5.ProviderServer to allow for easier protocol testing.
2020-11-20 00:34:58 +01:00
}
resp.ProviderMeta = &tfplugin5.Schema{
Block: &tfplugin5.Schema_Block{},
}
add grpcwrap.Provisioner Rename grpcwrap.New() to grpcwrap.Provider() Add a grpcwrap function to create a test proivisioner plugin.
2020-11-26 00:02:21 +01:00
if p.schema.ProviderMeta.Block != nil {
resp.ProviderMeta.Block = convert.ConfigSchemaToProto(p.schema.ProviderMeta.Block)
grpcwrap: convert provider interface to grpcserver grpcwrap wraps a core providers.Interface and converts it to a tfplugin5.ProviderServer to allow for easier protocol testing.
2020-11-20 00:34:58 +01:00
}
add grpcwrap.Provisioner Rename grpcwrap.New() to grpcwrap.Provider() Add a grpcwrap function to create a test proivisioner plugin.
2020-11-26 00:02:21 +01:00
for typ, res := range p.schema.ResourceTypes {
grpcwrap: convert provider interface to grpcserver grpcwrap wraps a core providers.Interface and converts it to a tfplugin5.ProviderServer to allow for easier protocol testing.
2020-11-20 00:34:58 +01:00
resp.ResourceSchemas[typ] = &tfplugin5.Schema{
Version: res.Version,
Block: convert.ConfigSchemaToProto(res.Block),
}
}
add grpcwrap.Provisioner Rename grpcwrap.New() to grpcwrap.Provider() Add a grpcwrap function to create a test proivisioner plugin.
2020-11-26 00:02:21 +01:00
for typ, dat := range p.schema.DataSources {
grpcwrap: convert provider interface to grpcserver grpcwrap wraps a core providers.Interface and converts it to a tfplugin5.ProviderServer to allow for easier protocol testing.
2020-11-20 00:34:58 +01:00
resp.DataSourceSchemas[typ] = &tfplugin5.Schema{
Version: dat.Version,
Block: convert.ConfigSchemaToProto(dat.Block),
}
}
// include any diagnostics from the original GetSchema call
add grpcwrap.Provisioner Rename grpcwrap.New() to grpcwrap.Provider() Add a grpcwrap function to create a test proivisioner plugin.
2020-11-26 00:02:21 +01:00
resp.Diagnostics = convert.AppendProtoDiag(resp.Diagnostics, p.schema.Diagnostics)
grpcwrap: convert provider interface to grpcserver grpcwrap wraps a core providers.Interface and converts it to a tfplugin5.ProviderServer to allow for easier protocol testing.
2020-11-20 00:34:58 +01:00
return resp, nil
}
add grpcwrap.Provisioner Rename grpcwrap.New() to grpcwrap.Provider() Add a grpcwrap function to create a test proivisioner plugin.
2020-11-26 00:02:21 +01:00
func (p *provider) PrepareProviderConfig(_ context.Context, req *tfplugin5.PrepareProviderConfig_Request) (*tfplugin5.PrepareProviderConfig_Response, error) {
grpcwrap: convert provider interface to grpcserver grpcwrap wraps a core providers.Interface and converts it to a tfplugin5.ProviderServer to allow for easier protocol testing.
2020-11-20 00:34:58 +01:00
resp := &tfplugin5.PrepareProviderConfig_Response{}
add grpcwrap.Provisioner Rename grpcwrap.New() to grpcwrap.Provider() Add a grpcwrap function to create a test proivisioner plugin.
2020-11-26 00:02:21 +01:00
ty := p.schema.Provider.Block.ImpliedType()
grpcwrap: convert provider interface to grpcserver grpcwrap wraps a core providers.Interface and converts it to a tfplugin5.ProviderServer to allow for easier protocol testing.
2020-11-20 00:34:58 +01:00
configVal, err := decodeDynamicValue(req.Config, ty)
if err != nil {
resp.Diagnostics = convert.AppendProtoDiag(resp.Diagnostics, err)
return resp, nil
}
Mildwonkey/providers interface renaming (#27805) * providers.Interface: huge renamification This commit renames a handful of functions in the providers.Interface to match changes made in protocol v6. The following commit implements this change across the rest of the codebase; I put this in a separate commit for ease of reviewing and will squash these together when merging. One noteworthy detail: protocol v6 removes the config from the ValidateProviderConfigResponse, since it's never been used. I chose to leave that in place in the interface until we deprecate support for protocol v5 entirely. Note that none of these changes impact current providers using protocol v5; the protocol is unchanged. Only the translation layer between the proto and terraform have changed.
2021-02-18 16:13:43 +01:00
prepareResp := p.provider.ValidateProviderConfig(providers.ValidateProviderConfigRequest{
grpcwrap: convert provider interface to grpcserver grpcwrap wraps a core providers.Interface and converts it to a tfplugin5.ProviderServer to allow for easier protocol testing.
2020-11-20 00:34:58 +01:00
Config: configVal,
})
// the PreparedConfig value is no longer used
resp.Diagnostics = convert.AppendProtoDiag(resp.Diagnostics, prepareResp.Diagnostics)
return resp, nil
}
add grpcwrap.Provisioner Rename grpcwrap.New() to grpcwrap.Provider() Add a grpcwrap function to create a test proivisioner plugin.
2020-11-26 00:02:21 +01:00
func (p *provider) ValidateResourceTypeConfig(_ context.Context, req *tfplugin5.ValidateResourceTypeConfig_Request) (*tfplugin5.ValidateResourceTypeConfig_Response, error) {
grpcwrap: convert provider interface to grpcserver grpcwrap wraps a core providers.Interface and converts it to a tfplugin5.ProviderServer to allow for easier protocol testing.
2020-11-20 00:34:58 +01:00
resp := &tfplugin5.ValidateResourceTypeConfig_Response{}
add grpcwrap.Provisioner Rename grpcwrap.New() to grpcwrap.Provider() Add a grpcwrap function to create a test proivisioner plugin.
2020-11-26 00:02:21 +01:00
ty := p.schema.ResourceTypes[req.TypeName].Block.ImpliedType()
grpcwrap: convert provider interface to grpcserver grpcwrap wraps a core providers.Interface and converts it to a tfplugin5.ProviderServer to allow for easier protocol testing.
2020-11-20 00:34:58 +01:00
configVal, err := decodeDynamicValue(req.Config, ty)
if err != nil {
resp.Diagnostics = convert.AppendProtoDiag(resp.Diagnostics, err)
return resp, nil
}
Mildwonkey/providers interface renaming (#27805) * providers.Interface: huge renamification This commit renames a handful of functions in the providers.Interface to match changes made in protocol v6. The following commit implements this change across the rest of the codebase; I put this in a separate commit for ease of reviewing and will squash these together when merging. One noteworthy detail: protocol v6 removes the config from the ValidateProviderConfigResponse, since it's never been used. I chose to leave that in place in the interface until we deprecate support for protocol v5 entirely. Note that none of these changes impact current providers using protocol v5; the protocol is unchanged. Only the translation layer between the proto and terraform have changed.
2021-02-18 16:13:43 +01:00
validateResp := p.provider.ValidateResourceConfig(providers.ValidateResourceConfigRequest{
grpcwrap: convert provider interface to grpcserver grpcwrap wraps a core providers.Interface and converts it to a tfplugin5.ProviderServer to allow for easier protocol testing.
2020-11-20 00:34:58 +01:00
TypeName: req.TypeName,
Config: configVal,
})
resp.Diagnostics = convert.AppendProtoDiag(resp.Diagnostics, validateResp.Diagnostics)
return resp, nil
}
add grpcwrap.Provisioner Rename grpcwrap.New() to grpcwrap.Provider() Add a grpcwrap function to create a test proivisioner plugin.
2020-11-26 00:02:21 +01:00
func (p *provider) ValidateDataSourceConfig(_ context.Context, req *tfplugin5.ValidateDataSourceConfig_Request) (*tfplugin5.ValidateDataSourceConfig_Response, error) {
grpcwrap: convert provider interface to grpcserver grpcwrap wraps a core providers.Interface and converts it to a tfplugin5.ProviderServer to allow for easier protocol testing.
2020-11-20 00:34:58 +01:00
resp := &tfplugin5.ValidateDataSourceConfig_Response{}
add grpcwrap.Provisioner Rename grpcwrap.New() to grpcwrap.Provider() Add a grpcwrap function to create a test proivisioner plugin.
2020-11-26 00:02:21 +01:00
ty := p.schema.DataSources[req.TypeName].Block.ImpliedType()
grpcwrap: convert provider interface to grpcserver grpcwrap wraps a core providers.Interface and converts it to a tfplugin5.ProviderServer to allow for easier protocol testing.
2020-11-20 00:34:58 +01:00
configVal, err := decodeDynamicValue(req.Config, ty)
if err != nil {
resp.Diagnostics = convert.AppendProtoDiag(resp.Diagnostics, err)
return resp, nil
}
providers.Interface: rename ValidateDataSourceConfig to ValidateDataResourceConfig (#27874) * providers.Interface: rename ValidateDataSourceConfig to ValidateDataResourceConfig This PR came about after renaming ValidateResourceTypeConfig to ValidateResourceConfig: I now understand that we'd called it the former instead of the latter to indicate that the function wasn't necessarily operating on a resource that actually exists. A possibly-more-accurate renaming of both functions might then be ValidateManagedResourceConfig and ValidateDataResourceConfig. The next commit will update the protocol (v6 only) as well; these are in separate commits for reviewers and will get squashed together before merging. * extend renaming to protov6
2021-02-24 18:04:28 +01:00
validateResp := p.provider.ValidateDataResourceConfig(providers.ValidateDataResourceConfigRequest{
grpcwrap: convert provider interface to grpcserver grpcwrap wraps a core providers.Interface and converts it to a tfplugin5.ProviderServer to allow for easier protocol testing.
2020-11-20 00:34:58 +01:00
TypeName: req.TypeName,
Config: configVal,
})
resp.Diagnostics = convert.AppendProtoDiag(resp.Diagnostics, validateResp.Diagnostics)
return resp, nil
}
add grpcwrap.Provisioner Rename grpcwrap.New() to grpcwrap.Provider() Add a grpcwrap function to create a test proivisioner plugin.
2020-11-26 00:02:21 +01:00
func (p *provider) UpgradeResourceState(_ context.Context, req *tfplugin5.UpgradeResourceState_Request) (*tfplugin5.UpgradeResourceState_Response, error) {
grpcwrap: convert provider interface to grpcserver grpcwrap wraps a core providers.Interface and converts it to a tfplugin5.ProviderServer to allow for easier protocol testing.
2020-11-20 00:34:58 +01:00
resp := &tfplugin5.UpgradeResourceState_Response{}
add grpcwrap.Provisioner Rename grpcwrap.New() to grpcwrap.Provider() Add a grpcwrap function to create a test proivisioner plugin.
2020-11-26 00:02:21 +01:00
ty := p.schema.ResourceTypes[req.TypeName].Block.ImpliedType()
grpcwrap: convert provider interface to grpcserver grpcwrap wraps a core providers.Interface and converts it to a tfplugin5.ProviderServer to allow for easier protocol testing.
2020-11-20 00:34:58 +01:00
add grpcwrap.Provisioner Rename grpcwrap.New() to grpcwrap.Provider() Add a grpcwrap function to create a test proivisioner plugin.
2020-11-26 00:02:21 +01:00
upgradeResp := p.provider.UpgradeResourceState(providers.UpgradeResourceStateRequest{
grpcwrap: convert provider interface to grpcserver grpcwrap wraps a core providers.Interface and converts it to a tfplugin5.ProviderServer to allow for easier protocol testing.
2020-11-20 00:34:58 +01:00
TypeName: req.TypeName,
Version: req.Version,
RawStateJSON: req.RawState.Json,
})
resp.Diagnostics = convert.AppendProtoDiag(resp.Diagnostics, upgradeResp.Diagnostics)
if upgradeResp.Diagnostics.HasErrors() {
return resp, nil
}
dv, err := encodeDynamicValue(upgradeResp.UpgradedState, ty)
if err != nil {
resp.Diagnostics = convert.AppendProtoDiag(resp.Diagnostics, err)
return resp, nil
}
resp.UpgradedState = dv
return resp, nil
}
add grpcwrap.Provisioner Rename grpcwrap.New() to grpcwrap.Provider() Add a grpcwrap function to create a test proivisioner plugin.
2020-11-26 00:02:21 +01:00
func (p *provider) Configure(_ context.Context, req *tfplugin5.Configure_Request) (*tfplugin5.Configure_Response, error) {
grpcwrap: convert provider interface to grpcserver grpcwrap wraps a core providers.Interface and converts it to a tfplugin5.ProviderServer to allow for easier protocol testing.
2020-11-20 00:34:58 +01:00
resp := &tfplugin5.Configure_Response{}
add grpcwrap.Provisioner Rename grpcwrap.New() to grpcwrap.Provider() Add a grpcwrap function to create a test proivisioner plugin.
2020-11-26 00:02:21 +01:00
ty := p.schema.Provider.Block.ImpliedType()
grpcwrap: convert provider interface to grpcserver grpcwrap wraps a core providers.Interface and converts it to a tfplugin5.ProviderServer to allow for easier protocol testing.
2020-11-20 00:34:58 +01:00
configVal, err := decodeDynamicValue(req.Config, ty)
if err != nil {
resp.Diagnostics = convert.AppendProtoDiag(resp.Diagnostics, err)
return resp, nil
}
Mildwonkey/providers interface renaming (#27805) * providers.Interface: huge renamification This commit renames a handful of functions in the providers.Interface to match changes made in protocol v6. The following commit implements this change across the rest of the codebase; I put this in a separate commit for ease of reviewing and will squash these together when merging. One noteworthy detail: protocol v6 removes the config from the ValidateProviderConfigResponse, since it's never been used. I chose to leave that in place in the interface until we deprecate support for protocol v5 entirely. Note that none of these changes impact current providers using protocol v5; the protocol is unchanged. Only the translation layer between the proto and terraform have changed.
2021-02-18 16:13:43 +01:00
configureResp := p.provider.ConfigureProvider(providers.ConfigureProviderRequest{
grpcwrap: convert provider interface to grpcserver grpcwrap wraps a core providers.Interface and converts it to a tfplugin5.ProviderServer to allow for easier protocol testing.
2020-11-20 00:34:58 +01:00
TerraformVersion: req.TerraformVersion,
Config: configVal,
})
resp.Diagnostics = convert.AppendProtoDiag(resp.Diagnostics, configureResp.Diagnostics)
return resp, nil
}
add grpcwrap.Provisioner Rename grpcwrap.New() to grpcwrap.Provider() Add a grpcwrap function to create a test proivisioner plugin.
2020-11-26 00:02:21 +01:00
func (p *provider) ReadResource(_ context.Context, req *tfplugin5.ReadResource_Request) (*tfplugin5.ReadResource_Response, error) {
grpcwrap: convert provider interface to grpcserver grpcwrap wraps a core providers.Interface and converts it to a tfplugin5.ProviderServer to allow for easier protocol testing.
2020-11-20 00:34:58 +01:00
resp := &tfplugin5.ReadResource_Response{}
add grpcwrap.Provisioner Rename grpcwrap.New() to grpcwrap.Provider() Add a grpcwrap function to create a test proivisioner plugin.
2020-11-26 00:02:21 +01:00
ty := p.schema.ResourceTypes[req.TypeName].Block.ImpliedType()
grpcwrap: convert provider interface to grpcserver grpcwrap wraps a core providers.Interface and converts it to a tfplugin5.ProviderServer to allow for easier protocol testing.
2020-11-20 00:34:58 +01:00
stateVal, err := decodeDynamicValue(req.CurrentState, ty)
if err != nil {
resp.Diagnostics = convert.AppendProtoDiag(resp.Diagnostics, err)
return resp, nil
}
add grpcwrap.Provisioner Rename grpcwrap.New() to grpcwrap.Provider() Add a grpcwrap function to create a test proivisioner plugin.
2020-11-26 00:02:21 +01:00
metaTy := p.schema.ProviderMeta.Block.ImpliedType()
grpcwrap: convert provider interface to grpcserver grpcwrap wraps a core providers.Interface and converts it to a tfplugin5.ProviderServer to allow for easier protocol testing.
2020-11-20 00:34:58 +01:00
metaVal, err := decodeDynamicValue(req.ProviderMeta, metaTy)
if err != nil {
resp.Diagnostics = convert.AppendProtoDiag(resp.Diagnostics, err)
return resp, nil
}
add grpcwrap.Provisioner Rename grpcwrap.New() to grpcwrap.Provider() Add a grpcwrap function to create a test proivisioner plugin.
2020-11-26 00:02:21 +01:00
readResp := p.provider.ReadResource(providers.ReadResourceRequest{
grpcwrap: convert provider interface to grpcserver grpcwrap wraps a core providers.Interface and converts it to a tfplugin5.ProviderServer to allow for easier protocol testing.
2020-11-20 00:34:58 +01:00
TypeName: req.TypeName,
PriorState: stateVal,
Private: req.Private,
ProviderMeta: metaVal,
})
resp.Diagnostics = convert.AppendProtoDiag(resp.Diagnostics, readResp.Diagnostics)
if readResp.Diagnostics.HasErrors() {
return resp, nil
}
resp.Private = readResp.Private
dv, err := encodeDynamicValue(readResp.NewState, ty)
if err != nil {
resp.Diagnostics = convert.AppendProtoDiag(resp.Diagnostics, err)
return resp, nil
}
resp.NewState = dv
return resp, nil
}
add grpcwrap.Provisioner Rename grpcwrap.New() to grpcwrap.Provider() Add a grpcwrap function to create a test proivisioner plugin.
2020-11-26 00:02:21 +01:00
func (p *provider) PlanResourceChange(_ context.Context, req *tfplugin5.PlanResourceChange_Request) (*tfplugin5.PlanResourceChange_Response, error) {
grpcwrap: convert provider interface to grpcserver grpcwrap wraps a core providers.Interface and converts it to a tfplugin5.ProviderServer to allow for easier protocol testing.
2020-11-20 00:34:58 +01:00
resp := &tfplugin5.PlanResourceChange_Response{}
add grpcwrap.Provisioner Rename grpcwrap.New() to grpcwrap.Provider() Add a grpcwrap function to create a test proivisioner plugin.
2020-11-26 00:02:21 +01:00
ty := p.schema.ResourceTypes[req.TypeName].Block.ImpliedType()
grpcwrap: convert provider interface to grpcserver grpcwrap wraps a core providers.Interface and converts it to a tfplugin5.ProviderServer to allow for easier protocol testing.
2020-11-20 00:34:58 +01:00
priorStateVal, err := decodeDynamicValue(req.PriorState, ty)
if err != nil {
resp.Diagnostics = convert.AppendProtoDiag(resp.Diagnostics, err)
return resp, nil
}
proposedStateVal, err := decodeDynamicValue(req.ProposedNewState, ty)
if err != nil {
resp.Diagnostics = convert.AppendProtoDiag(resp.Diagnostics, err)
return resp, nil
}
configVal, err := decodeDynamicValue(req.Config, ty)
if err != nil {
resp.Diagnostics = convert.AppendProtoDiag(resp.Diagnostics, err)
return resp, nil
}
add grpcwrap.Provisioner Rename grpcwrap.New() to grpcwrap.Provider() Add a grpcwrap function to create a test proivisioner plugin.
2020-11-26 00:02:21 +01:00
metaTy := p.schema.ProviderMeta.Block.ImpliedType()
grpcwrap: convert provider interface to grpcserver grpcwrap wraps a core providers.Interface and converts it to a tfplugin5.ProviderServer to allow for easier protocol testing.
2020-11-20 00:34:58 +01:00
metaVal, err := decodeDynamicValue(req.ProviderMeta, metaTy)
if err != nil {
resp.Diagnostics = convert.AppendProtoDiag(resp.Diagnostics, err)
return resp, nil
}
add grpcwrap.Provisioner Rename grpcwrap.New() to grpcwrap.Provider() Add a grpcwrap function to create a test proivisioner plugin.
2020-11-26 00:02:21 +01:00
planResp := p.provider.PlanResourceChange(providers.PlanResourceChangeRequest{
grpcwrap: convert provider interface to grpcserver grpcwrap wraps a core providers.Interface and converts it to a tfplugin5.ProviderServer to allow for easier protocol testing.
2020-11-20 00:34:58 +01:00
TypeName: req.TypeName,
PriorState: priorStateVal,
ProposedNewState: proposedStateVal,
Config: configVal,
PriorPrivate: req.PriorPrivate,
ProviderMeta: metaVal,
})
resp.Diagnostics = convert.AppendProtoDiag(resp.Diagnostics, planResp.Diagnostics)
if planResp.Diagnostics.HasErrors() {
return resp, nil
}
resp.PlannedPrivate = planResp.PlannedPrivate
resp.PlannedState, err = encodeDynamicValue(planResp.PlannedState, ty)
if err != nil {
resp.Diagnostics = convert.AppendProtoDiag(resp.Diagnostics, err)
return resp, nil
}
for _, path := range planResp.RequiresReplace {
resp.RequiresReplace = append(resp.RequiresReplace, convert.PathToAttributePath(path))
}
return resp, nil
}
add grpcwrap.Provisioner Rename grpcwrap.New() to grpcwrap.Provider() Add a grpcwrap function to create a test proivisioner plugin.
2020-11-26 00:02:21 +01:00
func (p *provider) ApplyResourceChange(_ context.Context, req *tfplugin5.ApplyResourceChange_Request) (*tfplugin5.ApplyResourceChange_Response, error) {
grpcwrap: convert provider interface to grpcserver grpcwrap wraps a core providers.Interface and converts it to a tfplugin5.ProviderServer to allow for easier protocol testing.
2020-11-20 00:34:58 +01:00
resp := &tfplugin5.ApplyResourceChange_Response{}
add grpcwrap.Provisioner Rename grpcwrap.New() to grpcwrap.Provider() Add a grpcwrap function to create a test proivisioner plugin.
2020-11-26 00:02:21 +01:00
ty := p.schema.ResourceTypes[req.TypeName].Block.ImpliedType()
grpcwrap: convert provider interface to grpcserver grpcwrap wraps a core providers.Interface and converts it to a tfplugin5.ProviderServer to allow for easier protocol testing.
2020-11-20 00:34:58 +01:00
priorStateVal, err := decodeDynamicValue(req.PriorState, ty)
if err != nil {
resp.Diagnostics = convert.AppendProtoDiag(resp.Diagnostics, err)
return resp, nil
}
plannedStateVal, err := decodeDynamicValue(req.PlannedState, ty)
if err != nil {
resp.Diagnostics = convert.AppendProtoDiag(resp.Diagnostics, err)
return resp, nil
}
configVal, err := decodeDynamicValue(req.Config, ty)
if err != nil {
resp.Diagnostics = convert.AppendProtoDiag(resp.Diagnostics, err)
return resp, nil
}
add grpcwrap.Provisioner Rename grpcwrap.New() to grpcwrap.Provider() Add a grpcwrap function to create a test proivisioner plugin.
2020-11-26 00:02:21 +01:00
metaTy := p.schema.ProviderMeta.Block.ImpliedType()
grpcwrap: convert provider interface to grpcserver grpcwrap wraps a core providers.Interface and converts it to a tfplugin5.ProviderServer to allow for easier protocol testing.
2020-11-20 00:34:58 +01:00
metaVal, err := decodeDynamicValue(req.ProviderMeta, metaTy)
if err != nil {
resp.Diagnostics = convert.AppendProtoDiag(resp.Diagnostics, err)
return resp, nil
}
add grpcwrap.Provisioner Rename grpcwrap.New() to grpcwrap.Provider() Add a grpcwrap function to create a test proivisioner plugin.
2020-11-26 00:02:21 +01:00
applyResp := p.provider.ApplyResourceChange(providers.ApplyResourceChangeRequest{
grpcwrap: convert provider interface to grpcserver grpcwrap wraps a core providers.Interface and converts it to a tfplugin5.ProviderServer to allow for easier protocol testing.
2020-11-20 00:34:58 +01:00
TypeName: req.TypeName,
PriorState: priorStateVal,
PlannedState: plannedStateVal,
Config: configVal,
PlannedPrivate: req.PlannedPrivate,
ProviderMeta: metaVal,
})
resp.Diagnostics = convert.AppendProtoDiag(resp.Diagnostics, applyResp.Diagnostics)
if applyResp.Diagnostics.HasErrors() {
return resp, nil
}
resp.Private = applyResp.Private
resp.NewState, err = encodeDynamicValue(applyResp.NewState, ty)
if err != nil {
resp.Diagnostics = convert.AppendProtoDiag(resp.Diagnostics, err)
return resp, nil
}
return resp, nil
}
add grpcwrap.Provisioner Rename grpcwrap.New() to grpcwrap.Provider() Add a grpcwrap function to create a test proivisioner plugin.
2020-11-26 00:02:21 +01:00
func (p *provider) ImportResourceState(_ context.Context, req *tfplugin5.ImportResourceState_Request) (*tfplugin5.ImportResourceState_Response, error) {
grpcwrap: convert provider interface to grpcserver grpcwrap wraps a core providers.Interface and converts it to a tfplugin5.ProviderServer to allow for easier protocol testing.
2020-11-20 00:34:58 +01:00
resp := &tfplugin5.ImportResourceState_Response{}
add grpcwrap.Provisioner Rename grpcwrap.New() to grpcwrap.Provider() Add a grpcwrap function to create a test proivisioner plugin.
2020-11-26 00:02:21 +01:00
importResp := p.provider.ImportResourceState(providers.ImportResourceStateRequest{
grpcwrap: convert provider interface to grpcserver grpcwrap wraps a core providers.Interface and converts it to a tfplugin5.ProviderServer to allow for easier protocol testing.
2020-11-20 00:34:58 +01:00
TypeName: req.TypeName,
ID: req.Id,
})
resp.Diagnostics = convert.AppendProtoDiag(resp.Diagnostics, importResp.Diagnostics)
for _, res := range importResp.ImportedResources {
add grpcwrap.Provisioner Rename grpcwrap.New() to grpcwrap.Provider() Add a grpcwrap function to create a test proivisioner plugin.
2020-11-26 00:02:21 +01:00
ty := p.schema.ResourceTypes[res.TypeName].Block.ImpliedType()
grpcwrap: convert provider interface to grpcserver grpcwrap wraps a core providers.Interface and converts it to a tfplugin5.ProviderServer to allow for easier protocol testing.
2020-11-20 00:34:58 +01:00
state, err := encodeDynamicValue(res.State, ty)
if err != nil {
resp.Diagnostics = convert.AppendProtoDiag(resp.Diagnostics, err)
continue
}
resp.ImportedResources = append(resp.ImportedResources, &tfplugin5.ImportResourceState_ImportedResource{
TypeName: res.TypeName,
State: state,
Private: res.Private,
})
}
return resp, nil
}
add grpcwrap.Provisioner Rename grpcwrap.New() to grpcwrap.Provider() Add a grpcwrap function to create a test proivisioner plugin.
2020-11-26 00:02:21 +01:00
func (p *provider) ReadDataSource(_ context.Context, req *tfplugin5.ReadDataSource_Request) (*tfplugin5.ReadDataSource_Response, error) {
grpcwrap: convert provider interface to grpcserver grpcwrap wraps a core providers.Interface and converts it to a tfplugin5.ProviderServer to allow for easier protocol testing.
2020-11-20 00:34:58 +01:00
resp := &tfplugin5.ReadDataSource_Response{}
add grpcwrap.Provisioner Rename grpcwrap.New() to grpcwrap.Provider() Add a grpcwrap function to create a test proivisioner plugin.
2020-11-26 00:02:21 +01:00
ty := p.schema.DataSources[req.TypeName].Block.ImpliedType()
grpcwrap: convert provider interface to grpcserver grpcwrap wraps a core providers.Interface and converts it to a tfplugin5.ProviderServer to allow for easier protocol testing.
2020-11-20 00:34:58 +01:00
configVal, err := decodeDynamicValue(req.Config, ty)
if err != nil {
resp.Diagnostics = convert.AppendProtoDiag(resp.Diagnostics, err)
return resp, nil
}
add grpcwrap.Provisioner Rename grpcwrap.New() to grpcwrap.Provider() Add a grpcwrap function to create a test proivisioner plugin.
2020-11-26 00:02:21 +01:00
metaTy := p.schema.ProviderMeta.Block.ImpliedType()
grpcwrap: convert provider interface to grpcserver grpcwrap wraps a core providers.Interface and converts it to a tfplugin5.ProviderServer to allow for easier protocol testing.
2020-11-20 00:34:58 +01:00
metaVal, err := decodeDynamicValue(req.ProviderMeta, metaTy)
if err != nil {
resp.Diagnostics = convert.AppendProtoDiag(resp.Diagnostics, err)
return resp, nil
}
add grpcwrap.Provisioner Rename grpcwrap.New() to grpcwrap.Provider() Add a grpcwrap function to create a test proivisioner plugin.
2020-11-26 00:02:21 +01:00
readResp := p.provider.ReadDataSource(providers.ReadDataSourceRequest{
grpcwrap: convert provider interface to grpcserver grpcwrap wraps a core providers.Interface and converts it to a tfplugin5.ProviderServer to allow for easier protocol testing.
2020-11-20 00:34:58 +01:00
TypeName: req.TypeName,
Config: configVal,
ProviderMeta: metaVal,
})
resp.Diagnostics = convert.AppendProtoDiag(resp.Diagnostics, readResp.Diagnostics)
if readResp.Diagnostics.HasErrors() {
return resp, nil
}
resp.State, err = encodeDynamicValue(readResp.State, ty)
if err != nil {
resp.Diagnostics = convert.AppendProtoDiag(resp.Diagnostics, err)
return resp, nil
}
return resp, nil
}
add grpcwrap.Provisioner Rename grpcwrap.New() to grpcwrap.Provider() Add a grpcwrap function to create a test proivisioner plugin.
2020-11-26 00:02:21 +01:00
func (p *provider) Stop(context.Context, *tfplugin5.Stop_Request) (*tfplugin5.Stop_Response, error) {
grpcwrap: convert provider interface to grpcserver grpcwrap wraps a core providers.Interface and converts it to a tfplugin5.ProviderServer to allow for easier protocol testing.
2020-11-20 00:34:58 +01:00
resp := &tfplugin5.Stop_Response{}
add grpcwrap.Provisioner Rename grpcwrap.New() to grpcwrap.Provider() Add a grpcwrap function to create a test proivisioner plugin.
2020-11-26 00:02:21 +01:00
err := p.provider.Stop()
grpcwrap: convert provider interface to grpcserver grpcwrap wraps a core providers.Interface and converts it to a tfplugin5.ProviderServer to allow for easier protocol testing.
2020-11-20 00:34:58 +01:00
if err != nil {
resp.Error = err.Error()
}
return resp, nil
}
// decode a DynamicValue from either the JSON or MsgPack encoding.
func decodeDynamicValue(v *tfplugin5.DynamicValue, ty cty.Type) (cty.Value, error) {
// always return a valid value
var err error
res := cty.NullVal(ty)
if v == nil {
return res, nil
}
switch {
case len(v.Msgpack) > 0:
res, err = msgpack.Unmarshal(v.Msgpack, ty)
case len(v.Json) > 0:
res, err = ctyjson.Unmarshal(v.Json, ty)
}
return res, err
}
// encode a cty.Value into a DynamicValue msgpack payload.
func encodeDynamicValue(v cty.Value, ty cty.Type) (*tfplugin5.DynamicValue, error) {
mp, err := msgpack.Marshal(v, ty)
return &tfplugin5.DynamicValue{
Msgpack: mp,
}, err
}