Add server implementation.

Add a tfprotov5server package that will let us build a gRPC server to
serve our tfprotov5.ProviderServer interface implementations with. It
mostly just translates between tfplugin5 and tfprotov5 types using the
fromproto and toproto packages.

I would've liked to put this in the tfprotov5 package, but unfortunately
that creates an import cycle with toproto and fromproto, and I'm not
sure how else to get around that besides collapsing everything down to a
single package, which I'm loathe to do because it'll pollute the
namespace something horrible, and make it really hard to see what's
going on in the package.

Author: Paddy Carver

tfprotov5/server/server.go

@@ -0,0 +1,212 @@
+package tfprotov5server
+
+import (
+	"context"
+
+	"github.com/hashicorp/terraform-plugin-go/tfprotov5"
+	"github.com/hashicorp/terraform-plugin-go/tfprotov5/internal/fromproto"
+	"github.com/hashicorp/terraform-plugin-go/tfprotov5/internal/tfplugin5"
+	"github.com/hashicorp/terraform-plugin-go/tfprotov5/internal/toproto"
+)
+
+type server struct {
+	downstream tfprotov5.ProviderServer
+}
+
+func New(serve tfprotov5.ProviderServer) tfplugin5.ProviderServer {
+	return server{
+		downstream: serve,
+	}
+}
+
+func (s server) GetSchema(ctx context.Context, req *tfplugin5.GetProviderSchema_Request) (*tfplugin5.GetProviderSchema_Response, error) {
+	r, err := fromproto.GetProviderSchemaRequest(*req)
+	if err != nil {
+		return nil, err
+	}
+	resp, err := s.downstream.GetProviderSchema(ctx, &r)
+	if err != nil {
+		return nil, err
+	}
+	ret, err := toproto.GetProviderSchema_Response(*resp)
+	if err != nil {
+		return nil, err
+	}
+	return &ret, nil
+}
+
+func (s server) PrepareProviderConfig(ctx context.Context, req *tfplugin5.PrepareProviderConfig_Request) (*tfplugin5.PrepareProviderConfig_Response, error) {
+	r, err := fromproto.PrepareProviderConfigRequest(*req)
+	if err != nil {
+		return nil, err
+	}
+	resp, err := s.downstream.PrepareProviderConfig(ctx, &r)
+	if err != nil {
+		return nil, err
+	}
+	ret, err := toproto.PrepareProviderConfig_Response(*resp)
+	if err != nil {
+		return nil, err
+	}
+	return &ret, nil
+}
+
+func (s server) Configure(ctx context.Context, req *tfplugin5.Configure_Request) (*tfplugin5.Configure_Response, error) {
+	r, err := fromproto.ConfigureProviderRequest(*req)
+	if err != nil {
+		return nil, err
+	}
+	resp, err := s.downstream.ConfigureProvider(ctx, &r)
+	if err != nil {
+		return nil, err
+	}
+	ret, err := toproto.Configure_Response(*resp)
+	if err != nil {
+		return nil, err
+	}
+	return &ret, nil
+}
+
+func (s server) Stop(ctx context.Context, req *tfplugin5.Stop_Request) (*tfplugin5.Stop_Response, error) {
+	r, err := fromproto.StopProviderRequest(*req)
+	if err != nil {
+		return nil, err
+	}
+	resp, err := s.downstream.StopProvider(ctx, &r)
+	if err != nil {
+		return nil, err
+	}
+	ret, err := toproto.Stop_Response(*resp)
+	if err != nil {
+		return nil, err
+	}
+	return &ret, nil
+}
+
+func (s server) ValidateDataSourceConfig(ctx context.Context, req *tfplugin5.ValidateDataSourceConfig_Request) (*tfplugin5.ValidateDataSourceConfig_Response, error) {
+	r, err := fromproto.ValidateDataSourceConfigRequest(*req)
+	if err != nil {
+		return nil, err
+	}
+	resp, err := s.downstream.ValidateDataSourceConfig(ctx, &r)
+	if err != nil {
+		return nil, err
+	}
+	ret, err := toproto.ValidateDataSourceConfig_Response(*resp)
+	if err != nil {
+		return nil, err
+	}
+	return &ret, nil
+}
+
+func (s server) ReadDataSource(ctx context.Context, req *tfplugin5.ReadDataSource_Request) (*tfplugin5.ReadDataSource_Response, error) {
+	r, err := fromproto.ReadDataSourceRequest(*req)
+	if err != nil {
+		return nil, err
+	}
+	resp, err := s.downstream.ReadDataSource(ctx, &r)
+	if err != nil {
+		return nil, err
+	}
+	ret, err := toproto.ReadDataSource_Response(*resp)
+	if err != nil {
+		return nil, err
+	}
+	return &ret, nil
+}
+
+func (s server) ValidateResourceTypeConfig(ctx context.Context, req *tfplugin5.ValidateResourceTypeConfig_Request) (*tfplugin5.ValidateResourceTypeConfig_Response, error) {
+	r, err := fromproto.ValidateResourceTypeConfigRequest(*req)
+	if err != nil {
+		return nil, err
+	}
+	resp, err := s.downstream.ValidateResourceTypeConfig(ctx, &r)
+	if err != nil {
+		return nil, err
+	}
+	ret, err := toproto.ValidateResourceTypeConfig_Response(*resp)
+	if err != nil {
+		return nil, err
+	}
+	return &ret, nil
+}
+
+func (s server) UpgradeResourceState(ctx context.Context, req *tfplugin5.UpgradeResourceState_Request) (*tfplugin5.UpgradeResourceState_Response, error) {
+	r, err := fromproto.UpgradeResourceStateRequest(*req)
+	if err != nil {
+		return nil, err
+	}
+	resp, err := s.downstream.UpgradeResourceState(ctx, &r)
+	if err != nil {
+		return nil, err
+	}
+	ret, err := toproto.UpgradeResourceState_Response(*resp)
+	if err != nil {
+		return nil, err
+	}
+	return &ret, nil
+}
+
+func (s server) ReadResource(ctx context.Context, req *tfplugin5.ReadResource_Request) (*tfplugin5.ReadResource_Response, error) {
+	r, err := fromproto.ReadResourceRequest(*req)
+	if err != nil {
+		return nil, err
+	}
+	resp, err := s.downstream.ReadResource(ctx, &r)
+	if err != nil {
+		return nil, err
+	}
+	ret, err := toproto.ReadResource_Response(*resp)
+	if err != nil {
+		return nil, err
+	}
+	return &ret, nil
+}
+
+func (s server) PlanResourceChange(ctx context.Context, req *tfplugin5.PlanResourceChange_Request) (*tfplugin5.PlanResourceChange_Response, error) {
+	r, err := fromproto.PlanResourceChangeRequest(*req)
+	if err != nil {
+		return nil, err
+	}
+	resp, err := s.downstream.PlanResourceChange(ctx, &r)
+	if err != nil {
+		return nil, err
+	}
+	ret, err := toproto.PlanResourceChange_Response(*resp)
+	if err != nil {
+		return nil, err
+	}
+	return &ret, nil
+}
+
+func (s server) ApplyResourceChange(ctx context.Context, req *tfplugin5.ApplyResourceChange_Request) (*tfplugin5.ApplyResourceChange_Response, error) {
+	r, err := fromproto.ApplyResourceChangeRequest(*req)
+	if err != nil {
+		return nil, err
+	}
+	resp, err := s.downstream.ApplyResourceChange(ctx, &r)
+	if err != nil {
+		return nil, err
+	}
+	ret, err := toproto.ApplyResourceChange_Response(*resp)
+	if err != nil {
+		return nil, err
+	}
+	return &ret, nil
+}
+
+func (s server) ImportResourceState(ctx context.Context, req *tfplugin5.ImportResourceState_Request) (*tfplugin5.ImportResourceState_Response, error) {
+	r, err := fromproto.ImportResourceStateRequest(*req)
+	if err != nil {
+		return nil, err
+	}
+	resp, err := s.downstream.ImportResourceState(ctx, &r)
+	if err != nil {
+		return nil, err
+	}
+	ret, err := toproto.ImportResourceState_Response(*resp)
+	if err != nil {
+		return nil, err
+	}
+	return &ret, nil
+}