Started adding ListResourceRPC

Author: rainkwan

go.mod

@@ -6,9 +6,9 @@ toolchain go1.23.7
 
 require (
 github.com/google/go-cmp v0.7.0
-github.com/hashicorp/terraform-plugin-go v0.28.1-0.20250604150620-c6d59498a4e1
+github.com/hashicorp/terraform-plugin-go v0.28.1-0.20250612152444-53272eefdb72
 github.com/hashicorp/terraform-plugin-log v0.9.0
-google.golang.org/grpc v1.72.2
+google.golang.org/grpc v1.73.0
 )
 
 require (
@@ -17,7 +17,7 @@ require (
 github.com/hashicorp/go-hclog v1.5.0 // indirect
 github.com/hashicorp/go-plugin v1.6.3 // indirect
 github.com/hashicorp/go-uuid v1.0.3 // indirect
-github.com/hashicorp/terraform-registry-address v0.2.5 // indirect
+github.com/hashicorp/terraform-registry-address v0.3.0 // indirect
 github.com/hashicorp/terraform-svchost v0.1.1 // indirect
 github.com/hashicorp/yamux v0.1.1 // indirect
 github.com/mattn/go-colorable v0.1.12 // indirect
@@ -26,9 +26,9 @@ require (
 github.com/oklog/run v1.0.0 // indirect
 github.com/vmihailenco/msgpack/v5 v5.4.1 // indirect
 github.com/vmihailenco/tagparser/v2 v2.0.0 // indirect
-golang.org/x/net v0.39.0 // indirect
-golang.org/x/sys v0.32.0 // indirect
-golang.org/x/text v0.24.0 // indirect
-google.golang.org/genproto/googleapis/rpc v0.0.0-20250218202821-56aae31c358a // indirect
+golang.org/x/net v0.41.0 // indirect
+golang.org/x/sys v0.33.0 // indirect
+golang.org/x/text v0.26.0 // indirect
+google.golang.org/genproto/googleapis/rpc v0.0.0-20250324211829-b45e905df463 // indirect
 google.golang.org/protobuf v1.36.6 // indirect
 )

go.sum

@@ -21,12 +21,12 @@ github.com/hashicorp/go-plugin v1.6.3 h1:xgHB+ZUSYeuJi96WtxEjzi23uh7YQpznjGh0U0U
 github.com/hashicorp/go-plugin v1.6.3/go.mod h1:MRobyh+Wc/nYy1V4KAXUiYfzxoYhs7V1mlH1Z7iY2h0=
 github.com/hashicorp/go-uuid v1.0.3 h1:2gKiV6YVmrJ1i2CKKa9obLvRieoRGviZFL26PcT/Co8=
 github.com/hashicorp/go-uuid v1.0.3/go.mod h1:6SBZvOh/SIDV7/2o3Jml5SYk/TvGqwFJ/bN7x4byOro=
-github.com/hashicorp/terraform-plugin-go v0.28.1-0.20250604150620-c6d59498a4e1 h1:TbYGMFWFJDeGgLf5r/vZ8U7sV/f8dg3PR/tDDV4lw/I=
-github.com/hashicorp/terraform-plugin-go v0.28.1-0.20250604150620-c6d59498a4e1/go.mod h1:2t+AK4nKnRw39xPaCHHEMz79e8BIZoEWsSsVUkC8jVU=
+github.com/hashicorp/terraform-plugin-go v0.28.1-0.20250612152444-53272eefdb72 h1:hi/mixv0JfFu6gfADLdFvq5S+HDSpldIgOdz+FfdUEU=
+github.com/hashicorp/terraform-plugin-go v0.28.1-0.20250612152444-53272eefdb72/go.mod h1:hL//wLEfYo0YVt0TC/VLzia/ADQQto3HEm4/jX2gkdY=
 github.com/hashicorp/terraform-plugin-log v0.9.0 h1:i7hOA+vdAItN1/7UrfBqBwvYPQ9TFvymaRGZED3FCV0=
 github.com/hashicorp/terraform-plugin-log v0.9.0/go.mod h1:rKL8egZQ/eXSyDqzLUuwUYLVdlYeamldAHSxjUFADow=
-github.com/hashicorp/terraform-registry-address v0.2.5 h1:2GTftHqmUhVOeuu9CW3kwDkRe4pcBDq0uuK5VJngU1M=
-github.com/hashicorp/terraform-registry-address v0.2.5/go.mod h1:PpzXWINwB5kuVS5CA7m1+eO2f1jKb5ZDIxrOPfpnGkg=
+github.com/hashicorp/terraform-registry-address v0.3.0 h1:HMpK3nqaGFPS9VmgRXrJL/dzHNdheGVKk5k7VlFxzCo=
+github.com/hashicorp/terraform-registry-address v0.3.0/go.mod h1:jRGCMiLaY9zii3GLC7hqpSnwhfnCN5yzvY0hh4iCGbM=
 github.com/hashicorp/terraform-svchost v0.1.1 h1:EZZimZ1GxdqFRinZ1tpJwVxxt49xc/S52uzrw4x0jKQ=
 github.com/hashicorp/terraform-svchost v0.1.1/go.mod h1:mNsjQfZyf/Jhz35v6/0LWcv26+X7JPS+buii2c9/ctc=
 github.com/hashicorp/yamux v0.1.1 h1:yrQxtgseBDrq9Y652vSRDvsKCJKOUD+GzTS4Y0Y8pvE=
@@ -56,32 +56,32 @@ github.com/vmihailenco/tagparser/v2 v2.0.0 h1:y09buUbR+b5aycVFQs/g70pqKVZNBmxwAh
 github.com/vmihailenco/tagparser/v2 v2.0.0/go.mod h1:Wri+At7QHww0WTrCBeu4J6bNtoV6mEfg5OIWRZA9qds=
 go.opentelemetry.io/auto/sdk v1.1.0 h1:cH53jehLUN6UFLY71z+NDOiNJqDdPRaXzTel0sJySYA=
 go.opentelemetry.io/auto/sdk v1.1.0/go.mod h1:3wSPjt5PWp2RhlCcmmOial7AvC4DQqZb7a7wCow3W8A=
-go.opentelemetry.io/otel v1.34.0 h1:zRLXxLCgL1WyKsPVrgbSdMN4c0FMkDAskSTQP+0hdUY=
-go.opentelemetry.io/otel v1.34.0/go.mod h1:OWFPOQ+h4G8xpyjgqo4SxJYdDQ/qmRH+wivy7zzx9oI=
-go.opentelemetry.io/otel/metric v1.34.0 h1:+eTR3U0MyfWjRDhmFMxe2SsW64QrZ84AOhvqS7Y+PoQ=
-go.opentelemetry.io/otel/metric v1.34.0/go.mod h1:CEDrp0fy2D0MvkXE+dPV7cMi8tWZwX3dmaIhwPOaqHE=
-go.opentelemetry.io/otel/sdk v1.34.0 h1:95zS4k/2GOy069d321O8jWgYsW3MzVV+KuSPKp7Wr1A=
-go.opentelemetry.io/otel/sdk v1.34.0/go.mod h1:0e/pNiaMAqaykJGKbi+tSjWfNNHMTxoC9qANsCzbyxU=
-go.opentelemetry.io/otel/sdk/metric v1.34.0 h1:5CeK9ujjbFVL5c1PhLuStg1wxA7vQv7ce1EK0Gyvahk=
-go.opentelemetry.io/otel/sdk/metric v1.34.0/go.mod h1:jQ/r8Ze28zRKoNRdkjCZxfs6YvBTG1+YIqyFVFYec5w=
-go.opentelemetry.io/otel/trace v1.34.0 h1:+ouXS2V8Rd4hp4580a8q23bg0azF2nI8cqLYnC8mh/k=
-go.opentelemetry.io/otel/trace v1.34.0/go.mod h1:Svm7lSjQD7kG7KJ/MUHPVXSDGz2OX4h0M2jHBhmSfRE=
-golang.org/x/net v0.39.0 h1:ZCu7HMWDxpXpaiKdhzIfaltL9Lp31x/3fCP11bc6/fY=
-golang.org/x/net v0.39.0/go.mod h1:X7NRbYVEA+ewNkCNyJ513WmMdQ3BineSwVtN2zD/d+E=
+go.opentelemetry.io/otel v1.35.0 h1:xKWKPxrxB6OtMCbmMY021CqC45J+3Onta9MqjhnusiQ=
+go.opentelemetry.io/otel v1.35.0/go.mod h1:UEqy8Zp11hpkUrL73gSlELM0DupHoiq72dR+Zqel/+Y=
+go.opentelemetry.io/otel/metric v1.35.0 h1:0znxYu2SNyuMSQT4Y9WDWej0VpcsxkuklLa4/siN90M=
+go.opentelemetry.io/otel/metric v1.35.0/go.mod h1:nKVFgxBZ2fReX6IlyW28MgZojkoAkJGaE8CpgeAU3oE=
+go.opentelemetry.io/otel/sdk v1.35.0 h1:iPctf8iprVySXSKJffSS79eOjl9pvxV9ZqOWT0QejKY=
+go.opentelemetry.io/otel/sdk v1.35.0/go.mod h1:+ga1bZliga3DxJ3CQGg3updiaAJoNECOgJREo9KHGQg=
+go.opentelemetry.io/otel/sdk/metric v1.35.0 h1:1RriWBmCKgkeHEhM7a2uMjMUfP7MsOF5JpUCaEqEI9o=
+go.opentelemetry.io/otel/sdk/metric v1.35.0/go.mod h1:is6XYCUMpcKi+ZsOvfluY5YstFnhW0BidkR+gL+qN+w=
+go.opentelemetry.io/otel/trace v1.35.0 h1:dPpEfJu1sDIqruz7BHFG3c7528f6ddfSWfFDVt/xgMs=
+go.opentelemetry.io/otel/trace v1.35.0/go.mod h1:WUk7DtFp1Aw2MkvqGdwiXYDZZNvA/1J8o6xRXLrIkyc=
+golang.org/x/net v0.41.0 h1:vBTly1HeNPEn3wtREYfy4GZ/NECgw2Cnl+nK6Nz3uvw=
+golang.org/x/net v0.41.0/go.mod h1:B/K4NNqkfmg07DQYrbwvSluqCJOOXwUjeb/5lOisjbA=
 golang.org/x/sys v0.0.0-20200116001909-b77594299b42/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
 golang.org/x/sys v0.0.0-20200223170610-d5e6a3e2c0ae/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
 golang.org/x/sys v0.0.0-20210630005230-0f9fa26af87c/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
 golang.org/x/sys v0.0.0-20210927094055-39ccf1dd6fa6/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
 golang.org/x/sys v0.0.0-20220503163025-988cb79eb6c6/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
 golang.org/x/sys v0.0.0-20220811171246-fbc7d0a398ab/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
-golang.org/x/sys v0.32.0 h1:s77OFDvIQeibCmezSnk/q6iAfkdiQaJi4VzroCFrN20=
-golang.org/x/sys v0.32.0/go.mod h1:BJP2sWEmIv4KK5OTEluFJCKSidICx8ciO85XgH3Ak8k=
-golang.org/x/text v0.24.0 h1:dd5Bzh4yt5KYA8f9CJHCP4FB4D51c2c6JvN37xJJkJ0=
-golang.org/x/text v0.24.0/go.mod h1:L8rBsPeo2pSS+xqN0d5u2ikmjtmoJbDBT1b7nHvFCdU=
-google.golang.org/genproto/googleapis/rpc v0.0.0-20250218202821-56aae31c358a h1:51aaUVRocpvUOSQKM6Q7VuoaktNIaMCLuhZB6DKksq4=
-google.golang.org/genproto/googleapis/rpc v0.0.0-20250218202821-56aae31c358a/go.mod h1:uRxBH1mhmO8PGhU89cMcHaXKZqO+OfakD8QQO0oYwlQ=
-google.golang.org/grpc v1.72.2 h1:TdbGzwb82ty4OusHWepvFWGLgIbNo1/SUynEN0ssqv8=
-google.golang.org/grpc v1.72.2/go.mod h1:wH5Aktxcg25y1I3w7H69nHfXdOG3UiadoBtjh3izSDM=
+golang.org/x/sys v0.33.0 h1:q3i8TbbEz+JRD9ywIRlyRAQbM0qF7hu24q3teo2hbuw=
+golang.org/x/sys v0.33.0/go.mod h1:BJP2sWEmIv4KK5OTEluFJCKSidICx8ciO85XgH3Ak8k=
+golang.org/x/text v0.26.0 h1:P42AVeLghgTYr4+xUnTRKDMqpar+PtX7KWuNQL21L8M=
+golang.org/x/text v0.26.0/go.mod h1:QK15LZJUUQVJxhz7wXgxSy/CJaTFjd0G+YLonydOVQA=
+google.golang.org/genproto/googleapis/rpc v0.0.0-20250324211829-b45e905df463 h1:e0AIkUUhxyBKh6ssZNrAMeqhA7RKUj42346d1y02i2g=
+google.golang.org/genproto/googleapis/rpc v0.0.0-20250324211829-b45e905df463/go.mod h1:qQ0YXyHHx3XkvlzUtpXDkS29lDSafHMZBAZDc03LQ3A=
+google.golang.org/grpc v1.73.0 h1:VIWSmpI2MegBtTuFt5/JWy2oXxtjJ/e89Z70ImfD2ok=
+google.golang.org/grpc v1.73.0/go.mod h1:50sbHOUqWoCQGI8V2HQLJM0B+LMlIUjNSZmow7EVBQc=
 google.golang.org/protobuf v1.36.6 h1:z1NpPI8ku2WgiWnf+t9wTPsn6eP1L7ksHUlkfLvd9xY=
 google.golang.org/protobuf v1.36.6/go.mod h1:jduwjTPXsFjZGTmRluh+L6NjiWu7pchiJ2/5YcXBHnY=
 gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=

internal/tf5testserver/tf5testserver.go

@@ -66,6 +66,8 @@ type TestServer struct {
 ValidateResourceTypeConfigCalled map[string]bool
 
 ValidateListResourceConfigCalled map[string]bool
+
+ListResourceCalled map[string]bool
 }
 
 func (s *TestServer) ProviderServer() tfprotov5.ProviderServer {
@@ -284,3 +286,12 @@ func (s *TestServer) PrepareProviderConfig(_ context.Context, req *tfprotov5.Pre
 s.PrepareProviderConfigCalled = true
 return s.PrepareProviderConfigResponse, nil
 }
+
+func (s *TestServer) ListResource(_ context.Context, req *tfprotov5.ListResourceRequest) (*tfprotov5.ListResourceServerStream, error) {
+if s.ListResourceCalled == nil {
+s.ListResourceCalled = make(map[string]bool)
+}
+
+s.ListResourceCalled[req.TypeName] = true
+return nil, nil
+}

internal/tf6testserver/tf6testserver.go

@@ -66,6 +66,8 @@ type TestServer struct {
 ValidateResourceConfigCalled map[string]bool
 
 ValidateListResourceConfigCalled map[string]bool
+
+ListResourceCalled map[string]bool
 }
 
 func (s *TestServer) ProviderServer() tfprotov6.ProviderServer {
@@ -284,3 +286,12 @@ func (s *TestServer) ValidateListResourceConfig(_ context.Context, req *tfprotov
 s.ValidateListResourceConfigCalled[req.TypeName] = true
 return nil, nil
 }
+
+func (s *TestServer) ListResource(_ context.Context, req *tfprotov6.ListResourceRequest) (*tfprotov6.ListResourceServerStream, error) {
+if s.ListResourceCalled == nil {
+s.ListResourceCalled = make(map[string]bool)
+}
+
+s.ListResourceCalled[req.TypeName] = true
+return nil, nil
+}

internal/tfprotov5tov6/tfprotov5tov6.go

@@ -1016,3 +1016,41 @@ func ValidateListResourceConfigResponse(in *tfprotov5.ValidateListResourceConfig
 Diagnostics: Diagnostics(in.Diagnostics),
 }
 }
+
+func ListResourceRequest(in *tfprotov5.ListResourceRequest) *tfprotov6.ListResourceRequest {
+if in == nil {
+return nil
+}
+
+return &tfprotov6.ListResourceRequest{
+Config: DynamicValue(in.Config),
+TypeName: in.TypeName,
+}
+}
+
+func ListResourceServerStream(in *tfprotov5.ListResourceServerStream) *tfprotov6.ListResourceServerStream {
+if in == nil {
+return nil
+}
+
+return &tfprotov6.ListResourceServerStream{
+Results: func(yield func(tfprotov6.ListResourceResult) bool) {
+for res := range in.Results {
+yield(*ListResourceResult(&res))
+}
+},
+}
+}
+
+func ListResourceResult(in *tfprotov5.ListResourceResult) *tfprotov6.ListResourceResult {
+if in == nil {
+return nil
+}
+
+return &tfprotov6.ListResourceResult{
+DisplayName: in.DisplayName,
+Resource: DynamicValue(in.Resource),
+Identity: ResourceIdentityData(in.Identity),
+Diagnostics: Diagnostics(in.Diagnostics),
+}
+}

internal/tfprotov5tov6/tfprotov5tov6_test.go

@@ -2990,6 +2990,121 @@ func TestValidateListResourceConfigResponse(t *testing.T) {
 }
 }
 
+func TestListResourceRequest(t *testing.T) {
+t.Parallel()
+
+testCases := map[string]struct {
+in *tfprotov5.ListResourceRequest
+expected *tfprotov6.ListResourceRequest
+}{
+"nil": {
+in: nil,
+expected: nil,
+},
+"all-valid-fields": {
+in: &tfprotov5.ListResourceRequest{
+Config: &testTfprotov5DynamicValue,
+TypeName: "test_list_resource",
+},
+expected: &tfprotov6.ListResourceRequest{
+Config: &testTfprotov6DynamicValue,
+TypeName: "test_list_resource",
+},
+},
+}
+
+for name, testCase := range testCases {
+
+t.Run(name, func(t *testing.T) {
+t.Parallel()
+
+got := tfprotov5tov6.ListResourceRequest(testCase.in)
+
+if diff := cmp.Diff(got, testCase.expected); diff != "" {
+t.Errorf("unexpected difference: %s", diff)
+}
+})
+}
+}
+
+/*func TestListResourceServerStream(t *testing.T) {
+t.Parallel()
+
+testCases := map[string]struct {
+in *tfprotov5.ListResourceServerStream
+expected *tfprotov6.ListResourceServerStream
+}{
+"nil": {
+in: nil,
+expected: nil,
+},
+"all-valid-fields": {
+in: &tfprotov5.ListResourceServerStream{
+Results: slices.Values([]tfprotov5.ListResourceResult{
+{
+Diagnostics: testTfprotov5Diagnostics,
+},
+}),
+},
+expected: &tfprotov6.ListResourceServerStream{
+Results: slices.Values([]tfprotov6.ListResourceResult{
+{
+Diagnostics: testTfprotov6Diagnostics,
+},
+}),
+},
+},
+}
+
+for name, testCase := range testCases {
+
+t.Run(name, func(t *testing.T) {
+t.Parallel()
+
+got := tfprotov5tov6.ListResourceServerStream(testCase.in)
+
+if diff := cmp.Diff(got, testCase.expected); diff != "" {
+t.Errorf("unexpected difference: %s", diff)
+}
+})
+}
+}*/
+
+func TestListResourceResult(t *testing.T) {
+t.Parallel()
+
+testCases := map[string]struct {
+in *tfprotov5.ListResourceResult
+expected *tfprotov6.ListResourceResult
+}{
+"nil": {
+in: nil,
+expected: nil,
+},
+"all-valid-fields": {
+in: &tfprotov5.ListResourceResult{
+Diagnostics: testTfprotov5Diagnostics,
+},
+expected: &tfprotov6.ListResourceResult{
+Diagnostics: testTfprotov6Diagnostics,
+},
+},
+}
+
+for name, testCase := range testCases {
+
+t.Run(name, func(t *testing.T) {
+t.Parallel()
+
+got := tfprotov5tov6.ListResourceResult(testCase.in)
+
+if diff := cmp.Diff(got, testCase.expected); diff != "" {
+t.Errorf("unexpected difference: %s", diff)
+}
+})
+}
+}
+
 func pointer[T any](value T) *T {
 return &value
 }

internal/tfprotov6tov5/tfprotov6tov5.go

@@ -1083,3 +1083,41 @@ func ValidateListResourceConfigResponse(in *tfprotov6.ValidateListResourceConfig
 Diagnostics: Diagnostics(in.Diagnostics),
 }
 }
+
+func ListResourceRequest(in *tfprotov6.ListResourceRequest) *tfprotov5.ListResourceRequest {
+if in == nil {
+return nil
+}
+
+return &tfprotov5.ListResourceRequest{
+Config: DynamicValue(in.Config),
+TypeName: in.TypeName,
+}
+}
+
+func ListResourceServerStream(in *tfprotov6.ListResourceServerStream) *tfprotov5.ListResourceServerStream {
+if in == nil {
+return nil
+}
+
+return &tfprotov5.ListResourceServerStream{
+Results: func(yield func(tfprotov5.ListResourceResult) bool) {
+for res := range in.Results {
+yield(*ListResourceResult(&res))
+}
+},
+}
+}
+
+func ListResourceResult(in *tfprotov6.ListResourceResult) *tfprotov5.ListResourceResult {
+if in == nil {
+return nil
+}
+
+return &tfprotov5.ListResourceResult{
+DisplayName: in.DisplayName,
+Resource: DynamicValue(in.Resource),
+Identity: ResourceIdentityData(in.Identity),
+Diagnostics: Diagnostics(in.Diagnostics),
+}
+}