Merge pull request #44336 from oracle-community/odb-aws-lists

list data source

Author: johnsonaj

.changelog/44336.txt

@@ -0,0 +1,19 @@
+```release-note:new-data-source
+aws_odb_cloud_autonomous_vm_clusters
+```
+
+```release-note:new-data-source
+aws_odb_cloud_exadata_infrastructures
+```
+
+```release-note:new-data-source
+aws_odb_cloud_vm_clusters
+```
+
+```release-note:new-data-source
+aws_odb_networks
+```
+
+```release-note:new-data-source
+aws_odb_network_peering_connections
+```

internal/service/odb/cloud_autonomous_vm_clusters_data_source.go

@@ -0,0 +1,96 @@
+// Copyright (c) HashiCorp, Inc.
+// SPDX-License-Identifier: MPL-2.0
+
+package odb
+
+import (
+	"context"
+
+	"github.com/aws/aws-sdk-go-v2/service/odb"
+	"github.com/hashicorp/terraform-plugin-framework/datasource"
+	"github.com/hashicorp/terraform-plugin-framework/datasource/schema"
+	"github.com/hashicorp/terraform-plugin-framework/types"
+	"github.com/hashicorp/terraform-provider-aws/internal/create"
+	"github.com/hashicorp/terraform-provider-aws/internal/framework"
+	"github.com/hashicorp/terraform-provider-aws/internal/framework/flex"
+	fwtypes "github.com/hashicorp/terraform-provider-aws/internal/framework/types"
+	"github.com/hashicorp/terraform-provider-aws/names"
+)
+
+// Function annotations are used for datasource registration to the Provider. DO NOT EDIT.
+// @FrameworkDataSource("aws_odb_cloud_autonomous_vm_clusters", name="Cloud Autonomous Vm Clusters")
+func newDataSourceCloudAutonomousVmClustersList(context.Context) (datasource.DataSourceWithConfigure, error) {
+	return &dataSourceCloudAutonomousVmClustersList{}, nil
+}
+
+const (
+	DSNameCloudAutonomousVmClustersList = "Cloud Autonomous Vm Clusters List Data Source"
+)
+
+type dataSourceCloudAutonomousVmClustersList struct {
+	framework.DataSourceWithModel[cloudAutonomousVmClusterListModel]
+}
+
+func (d *dataSourceCloudAutonomousVmClustersList) Schema(ctx context.Context, req datasource.SchemaRequest, resp *datasource.SchemaResponse) {
+	resp.Schema = schema.Schema{
+		Attributes: map[string]schema.Attribute{
+			"cloud_autonomous_vm_clusters": schema.ListAttribute{
+				Computed:    true,
+				Description: "List of Cloud Autonomous VM Clusters. The list going to contain basic information about the cloud autonomous VM clusters.",
+				CustomType:  fwtypes.NewListNestedObjectTypeOf[cloudAutonomousVmClusterSummary](ctx),
+			},
+		},
+	}
+}
+
+// Data sources only have a read method.
+func (d *dataSourceCloudAutonomousVmClustersList) Read(ctx context.Context, req datasource.ReadRequest, resp *datasource.ReadResponse) {
+	conn := d.Meta().ODBClient(ctx)
+	var data cloudAutonomousVmClusterListModel
+	resp.Diagnostics.Append(req.Config.Get(ctx, &data)...)
+	if resp.Diagnostics.HasError() {
+		return
+	}
+	out, err := ListCloudAutonomousVmClusters(ctx, conn)
+	if err != nil {
+		resp.Diagnostics.AddError(
+			create.ProblemStandardMessage(names.ODB, create.ErrActionReading, DSNameCloudAutonomousVmClustersList, "", err),
+			err.Error(),
+		)
+		return
+	}
+	resp.Diagnostics.Append(flex.Flatten(ctx, out, &data)...)
+	if resp.Diagnostics.HasError() {
+		return
+	}
+	resp.Diagnostics.Append(resp.State.Set(ctx, &data)...)
+}
+
+func ListCloudAutonomousVmClusters(ctx context.Context, conn *odb.Client) (*odb.ListCloudAutonomousVmClustersOutput, error) {
+	out := odb.ListCloudAutonomousVmClustersOutput{}
+	paginator := odb.NewListCloudAutonomousVmClustersPaginator(conn, &odb.ListCloudAutonomousVmClustersInput{})
+	for paginator.HasMorePages() {
+		page, err := paginator.NextPage(ctx)
+		if err != nil {
+			return nil, err
+		}
+		out.CloudAutonomousVmClusters = append(out.CloudAutonomousVmClusters, page.CloudAutonomousVmClusters...)
+	}
+	return &out, nil
+}
+
+type cloudAutonomousVmClusterListModel struct {
+	framework.WithRegionModel
+	CloudAutonomousVmClusters fwtypes.ListNestedObjectValueOf[cloudAutonomousVmClusterSummary] `tfsdk:"cloud_autonomous_vm_clusters"`
+}
+
+type cloudAutonomousVmClusterSummary struct {
+	CloudAutonomousVmClusterArn  types.String `tfsdk:"arn"`
+	CloudAutonomousVmClusterId   types.String `tfsdk:"id"`
+	CloudExadataInfrastructureId types.String `tfsdk:"cloud_exadata_infrastructure_id"`
+	OdbNetworkId                 types.String `tfsdk:"odb_network_id"`
+	OciResourceAnchorName        types.String `tfsdk:"oci_resource_anchor_name"`
+	OciUrl                       types.String `tfsdk:"oci_url"`
+	Ocid                         types.String `tfsdk:"ocid"`
+	DisplayName                  types.String `tfsdk:"display_name"`
+}

internal/service/odb/cloud_autonomous_vm_clusters_data_source_test.go

@@ -0,0 +1,83 @@
+// Copyright (c) HashiCorp, Inc.
+// SPDX-License-Identifier: MPL-2.0
+
+package odb_test
+
+import (
+	"context"
+	"errors"
+	"strconv"
+	"testing"
+
+	"github.com/aws/aws-sdk-go-v2/service/odb"
+	"github.com/hashicorp/terraform-plugin-testing/helper/resource"
+	"github.com/hashicorp/terraform-plugin-testing/terraform"
+	"github.com/hashicorp/terraform-provider-aws/internal/acctest"
+	"github.com/hashicorp/terraform-provider-aws/internal/conns"
+	"github.com/hashicorp/terraform-provider-aws/internal/create"
+	tfodb "github.com/hashicorp/terraform-provider-aws/internal/service/odb"
+	"github.com/hashicorp/terraform-provider-aws/names"
+)
+
+type listAVMCListDSTest struct {
+}
+
+func TestAccODBListAutonomousVmClustersDataSource_basic(t *testing.T) {
+	ctx := acctest.Context(t)
+	var avmcListTest = listAVMCListDSTest{}
+	var output odb.ListCloudAutonomousVmClustersOutput
+
+	dataSourceName := "data.aws_odb_cloud_autonomous_vm_clusters.test"
+	resource.Test(t, resource.TestCase{
+		PreCheck: func() {
+			acctest.PreCheck(ctx, t)
+			avmcListTest.testAccPreCheck(ctx, t)
+		},
+		ErrorCheck:               acctest.ErrorCheck(t, names.ODBServiceID),
+		ProtoV5ProviderFactories: acctest.ProtoV5ProviderFactories,
+		Steps: []resource.TestStep{
+			{
+				Config: avmcListTest.basic(),
+				Check: resource.ComposeAggregateTestCheckFunc(
+					resource.ComposeTestCheckFunc(func(s *terraform.State) error {
+						avmcListTest.count(ctx, dataSourceName, &output)
+						resource.TestCheckResourceAttr(dataSourceName, "cloud_autonomous_vm_clusters.#", strconv.Itoa(len(output.CloudAutonomousVmClusters)))
+						return nil
+					},
+					),
+				),
+			},
+		},
+	})
+}
+
+func (listAVMCListDSTest) basic() string {
+	return `data "aws_odb_cloud_autonomous_vm_clusters" "test" {}`
+}
+
+func (listAVMCListDSTest) count(ctx context.Context, name string, list *odb.ListCloudAutonomousVmClustersOutput) resource.TestCheckFunc {
+	return func(s *terraform.State) error {
+		rs, ok := s.RootModule().Resources[name]
+		if !ok {
+			return create.Error(names.ODB, create.ErrActionCheckingExistence, tfodb.DSNameCloudAutonomousVmClustersList, name, errors.New("not found"))
+		}
+		conn := acctest.Provider.Meta().(*conns.AWSClient).ODBClient(ctx)
+		resp, err := tfodb.ListCloudAutonomousVmClusters(ctx, conn)
+		if err != nil {
+			return create.Error(names.ODB, create.ErrActionCheckingExistence, tfodb.DSNameCloudAutonomousVmClustersList, rs.Primary.ID, err)
+		}
+		list.CloudAutonomousVmClusters = resp.CloudAutonomousVmClusters
+		return nil
+	}
+}
+func (listAVMCListDSTest) testAccPreCheck(ctx context.Context, t *testing.T) {
+	conn := acctest.Provider.Meta().(*conns.AWSClient).ODBClient(ctx)
+	input := odb.ListCloudAutonomousVmClustersInput{}
+	_, err := conn.ListCloudAutonomousVmClusters(ctx, &input)
+	if acctest.PreCheckSkipError(err) {
+		t.Skipf("skipping acceptance testing: %s", err)
+	}
+	if err != nil {
+		t.Fatalf("unexpected PreCheck error: %s", err)
+	}
+}

internal/service/odb/cloud_exadata_infrastructures_data_source.go

@@ -0,0 +1,92 @@
+// Copyright (c) HashiCorp, Inc.
+// SPDX-License-Identifier: MPL-2.0
+
+package odb
+
+import (
+	"context"
+
+	"github.com/aws/aws-sdk-go-v2/service/odb"
+	"github.com/hashicorp/terraform-plugin-framework/datasource"
+	"github.com/hashicorp/terraform-plugin-framework/datasource/schema"
+	"github.com/hashicorp/terraform-plugin-framework/types"
+	"github.com/hashicorp/terraform-provider-aws/internal/create"
+	"github.com/hashicorp/terraform-provider-aws/internal/framework"
+	"github.com/hashicorp/terraform-provider-aws/internal/framework/flex"
+	fwtypes "github.com/hashicorp/terraform-provider-aws/internal/framework/types"
+	"github.com/hashicorp/terraform-provider-aws/names"
+)
+
+// @FrameworkDataSource("aws_odb_cloud_exadata_infrastructures", name="Cloud Exadata Infrastructures")
+func newDataSourceCloudExadataInfrastructuresList(context.Context) (datasource.DataSourceWithConfigure, error) {
+	return &dataSourceCloudExadataInfrastructuresList{}, nil
+}
+
+const (
+	DSNameCloudExadataInfrastructuresList = "Cloud Exadata Infrastructures List Data Source"
+)
+
+type dataSourceCloudExadataInfrastructuresList struct {
+	framework.DataSourceWithModel[cloudExadataInfrastructuresListDataSourceModel]
+}
+
+func (d *dataSourceCloudExadataInfrastructuresList) Schema(ctx context.Context, req datasource.SchemaRequest, resp *datasource.SchemaResponse) {
+	resp.Schema = schema.Schema{
+		Attributes: map[string]schema.Attribute{
+			"cloud_exadata_infrastructures": schema.ListAttribute{
+				Computed:    true,
+				Description: "List of Cloud Exadata Infrastructures. Returns basic information about the Cloud Exadata Infrastructures.",
+				CustomType:  fwtypes.NewListNestedObjectTypeOf[cloudExadataInfrastructureDataSourceListSummary](ctx),
+			},
+		},
+	}
+}
+
+func (d *dataSourceCloudExadataInfrastructuresList) Read(ctx context.Context, req datasource.ReadRequest, resp *datasource.ReadResponse) {
+	conn := d.Meta().ODBClient(ctx)
+	var data cloudExadataInfrastructuresListDataSourceModel
+	resp.Diagnostics.Append(req.Config.Get(ctx, &data)...)
+	if resp.Diagnostics.HasError() {
+		return
+	}
+	out, err := ListCloudExadataInfrastructures(ctx, conn)
+	if err != nil {
+		resp.Diagnostics.AddError(
+			create.ProblemStandardMessage(names.ODB, create.ErrActionReading, DSNameCloudExadataInfrastructuresList, "", err),
+			err.Error(),
+		)
+		return
+	}
+	resp.Diagnostics.Append(flex.Flatten(ctx, out, &data)...)
+	if resp.Diagnostics.HasError() {
+		return
+	}
+	resp.Diagnostics.Append(resp.State.Set(ctx, &data)...)
+}
+
+func ListCloudExadataInfrastructures(ctx context.Context, conn *odb.Client) (*odb.ListCloudExadataInfrastructuresOutput, error) {
+	var out odb.ListCloudExadataInfrastructuresOutput
+	paginator := odb.NewListCloudExadataInfrastructuresPaginator(conn, &odb.ListCloudExadataInfrastructuresInput{})
+	for paginator.HasMorePages() {
+		page, err := paginator.NextPage(ctx)
+		if err != nil {
+			return nil, err
+		}
+		out.CloudExadataInfrastructures = append(out.CloudExadataInfrastructures, page.CloudExadataInfrastructures...)
+	}
+	return &out, nil
+}
+
+type cloudExadataInfrastructuresListDataSourceModel struct {
+	framework.WithRegionModel
+	CloudExadataInfrastructures fwtypes.ListNestedObjectValueOf[cloudExadataInfrastructureDataSourceListSummary] `tfsdk:"cloud_exadata_infrastructures"`
+}
+
+type cloudExadataInfrastructureDataSourceListSummary struct {
+	CloudExadataInfrastructureArn types.String `tfsdk:"arn"`
+	CloudExadataInfrastructureId  types.String `tfsdk:"id"`
+	OciResourceAnchorName         types.String `tfsdk:"oci_resource_anchor_name"`
+	OciUrl                        types.String `tfsdk:"oci_url"`
+	Ocid                          types.String `tfsdk:"ocid"`
+	DisplayName                   types.String `tfsdk:"display_name"`
+}

internal/service/odb/cloud_exadata_infrastructures_data_source_test.go

@@ -0,0 +1,82 @@
+// Copyright (c) HashiCorp, Inc.
+// SPDX-License-Identifier: MPL-2.0
+
+package odb_test
+
+import (
+	"context"
+	"errors"
+	"strconv"
+	"testing"
+
+	"github.com/aws/aws-sdk-go-v2/service/odb"
+	"github.com/hashicorp/terraform-plugin-testing/helper/resource"
+	"github.com/hashicorp/terraform-plugin-testing/terraform"
+	"github.com/hashicorp/terraform-provider-aws/internal/acctest"
+	"github.com/hashicorp/terraform-provider-aws/internal/conns"
+	"github.com/hashicorp/terraform-provider-aws/internal/create"
+	tfodb "github.com/hashicorp/terraform-provider-aws/internal/service/odb"
+	"github.com/hashicorp/terraform-provider-aws/names"
+)
+
+type listExaInfraTest struct {
+}
+
+func TestAccODBListCloudExadataInfrastructuresDataSource_basic(t *testing.T) {
+	ctx := acctest.Context(t)
+	var listExaInfraDSTest = listExaInfraTest{}
+	var infraList odb.ListCloudExadataInfrastructuresOutput
+	dataSourceName := "data.aws_odb_cloud_exadata_infrastructures.test"
+	resource.Test(t, resource.TestCase{
+		PreCheck: func() {
+			acctest.PreCheck(ctx, t)
+			listExaInfraDSTest.testAccPreCheck(ctx, t)
+		},
+		ErrorCheck:               acctest.ErrorCheck(t, names.ODBServiceID),
+		ProtoV5ProviderFactories: acctest.ProtoV5ProviderFactories,
+		Steps: []resource.TestStep{
+			{
+				Config: listExaInfraDSTest.basic(),
+				Check: resource.ComposeAggregateTestCheckFunc(
+					resource.ComposeTestCheckFunc(func(s *terraform.State) error {
+						listExaInfraDSTest.countExaInfrastructures(ctx, dataSourceName, &infraList)
+						resource.TestCheckResourceAttr(dataSourceName, "cloud_exadata_infrastructures.#", strconv.Itoa(len(infraList.CloudExadataInfrastructures)))
+						return nil
+					},
+					),
+				),
+			},
+		},
+	})
+}
+
+func (listExaInfraTest) basic() string {
+	return `data "aws_odb_cloud_exadata_infrastructures" "test" {}`
+}
+
+func (listExaInfraTest) countExaInfrastructures(ctx context.Context, name string, listOfInfra *odb.ListCloudExadataInfrastructuresOutput) resource.TestCheckFunc {
+	return func(s *terraform.State) error {
+		rs, ok := s.RootModule().Resources[name]
+		if !ok {
+			return create.Error(names.ODB, create.ErrActionCheckingExistence, tfodb.DSNameCloudExadataInfrastructuresList, name, errors.New("not found"))
+		}
+		conn := acctest.Provider.Meta().(*conns.AWSClient).ODBClient(ctx)
+		resp, err := tfodb.ListCloudExadataInfrastructures(ctx, conn)
+		if err != nil {
+			return create.Error(names.ODB, create.ErrActionCheckingExistence, tfodb.DSNameCloudExadataInfrastructuresList, rs.Primary.ID, err)
+		}
+		listOfInfra.CloudExadataInfrastructures = resp.CloudExadataInfrastructures
+		return nil
+	}
+}
+func (listExaInfraTest) testAccPreCheck(ctx context.Context, t *testing.T) {
+	conn := acctest.Provider.Meta().(*conns.AWSClient).ODBClient(ctx)
+	input := odb.ListCloudExadataInfrastructuresInput{}
+	_, err := conn.ListCloudExadataInfrastructures(ctx, &input)
+	if acctest.PreCheckSkipError(err) {
+		t.Skipf("skipping acceptance testing: %s", err)
+	}
+	if err != nil {
+		t.Fatalf("unexpected PreCheck error: %s", err)
+	}
+}