feat: feat(r2_data_catalog): add Terraform resource

* feat(r2_data_catalog): add Terraform resource

Author: stainless-app[bot]

.stats.yml

@@ -1,4 +1,4 @@
 configured_endpoints: 1986
 openapi_spec_url: https://storage.googleapis.com/stainless-sdk-openapi-specs/cloudflare%2Fcloudflare-9ba099b7936091cc984d2a24fc4d32c3ffcb1d71d86412c8c9084d201e16b3ac.yml
 openapi_spec_hash: 45edc9a107cf5a5e3b204b230b0d336d
-config_hash: 5d8bd5002a6f78b6f162dc0420e905bf
+config_hash: 96b952e0e131fab925a95b84c093c64e

examples/data-sources/cloudflare_r2_data_catalog/data-source.tf

@@ -0,0 +1,4 @@
+data "cloudflare_r2_data_catalog" "example_r2_data_catalog" {
+  account_id = "0123456789abcdef0123456789abcdef"
+  bucket_name = "my-data-bucket"
+}

examples/resources/cloudflare_pipeline/import.sh

@@ -0,0 +1 @@
+$ terraform import cloudflare_r2_data_catalog.example '<account_id>/<bucket_name>'

examples/resources/cloudflare_pipeline_sink/import.sh

@@ -0,0 +1,4 @@
+resource "cloudflare_r2_data_catalog" "example_r2_data_catalog" {
+  account_id = "0123456789abcdef0123456789abcdef"
+  bucket_name = "my-data-bucket"
+}

examples/resources/cloudflare_pipeline_stream/import.sh

@@ -133,6 +133,7 @@ import (
 	"github.com/cloudflare/terraform-provider-cloudflare/internal/services/r2_bucket_lock"
 	"github.com/cloudflare/terraform-provider-cloudflare/internal/services/r2_bucket_sippy"
 	"github.com/cloudflare/terraform-provider-cloudflare/internal/services/r2_custom_domain"
+	"github.com/cloudflare/terraform-provider-cloudflare/internal/services/r2_data_catalog"
 	"github.com/cloudflare/terraform-provider-cloudflare/internal/services/r2_managed_domain"
 	"github.com/cloudflare/terraform-provider-cloudflare/internal/services/rate_limit"
 	"github.com/cloudflare/terraform-provider-cloudflare/internal/services/regional_hostname"
@@ -546,6 +547,7 @@ func (p *CloudflareProvider) Resources(ctx context.Context) []func() resource.Re
 		r2_bucket_event_notification.NewResource,
 		r2_bucket_lock.NewResource,
 		r2_bucket_sippy.NewResource,
+		r2_data_catalog.NewResource,
 		workers_for_platforms_dispatch_namespace.NewResource,
 		zero_trust_dex_test.NewResource,
 		zero_trust_device_managed_networks.NewResource,
@@ -855,6 +857,7 @@ func (p *CloudflareProvider) DataSources(ctx context.Context) []func() datasourc
 		r2_bucket_event_notification.NewR2BucketEventNotificationDataSource,
 		r2_bucket_lock.NewR2BucketLockDataSource,
 		r2_bucket_sippy.NewR2BucketSippyDataSource,
+		r2_data_catalog.NewR2DataCatalogDataSource,
 		workers_for_platforms_dispatch_namespace.NewWorkersForPlatformsDispatchNamespaceDataSource,
 		workers_for_platforms_dispatch_namespace.NewWorkersForPlatformsDispatchNamespacesDataSource,
 		zero_trust_dex_test.NewZeroTrustDEXTestDataSource,

examples/resources/cloudflare_r2_data_catalog/import.sh

@@ -0,0 +1,89 @@
+// File generated from our OpenAPI spec by Stainless. See CONTRIBUTING.md for details.
+
+package r2_data_catalog
+
+import (
+	"context"
+	"fmt"
+	"io"
+	"net/http"
+
+	"github.com/cloudflare/cloudflare-go/v6"
+	"github.com/cloudflare/cloudflare-go/v6/option"
+	"github.com/cloudflare/terraform-provider-cloudflare/internal/apijson"
+	"github.com/cloudflare/terraform-provider-cloudflare/internal/logging"
+	"github.com/hashicorp/terraform-plugin-framework/datasource"
+)
+
+type R2DataCatalogDataSource struct {
+	client *cloudflare.Client
+}
+
+var _ datasource.DataSourceWithConfigure = (*R2DataCatalogDataSource)(nil)
+
+func NewR2DataCatalogDataSource() datasource.DataSource {
+	return &R2DataCatalogDataSource{}
+}
+
+func (d *R2DataCatalogDataSource) Metadata(ctx context.Context, req datasource.MetadataRequest, resp *datasource.MetadataResponse) {
+	resp.TypeName = req.ProviderTypeName + "_r2_data_catalog"
+}
+
+func (d *R2DataCatalogDataSource) Configure(ctx context.Context, req datasource.ConfigureRequest, resp *datasource.ConfigureResponse) {
+	if req.ProviderData == nil {
+		return
+	}
+
+	client, ok := req.ProviderData.(*cloudflare.Client)
+
+	if !ok {
+		resp.Diagnostics.AddError(
+			"unexpected resource configure type",
+			fmt.Sprintf("Expected *cloudflare.Client, got: %T. Please report this issue to the provider developers.", req.ProviderData),
+		)
+
+		return
+	}
+
+	d.client = client
+}
+
+func (d *R2DataCatalogDataSource) Read(ctx context.Context, req datasource.ReadRequest, resp *datasource.ReadResponse) {
+	var data *R2DataCatalogDataSourceModel
+
+	resp.Diagnostics.Append(req.Config.Get(ctx, &data)...)
+
+	if resp.Diagnostics.HasError() {
+		return
+	}
+
+	params, diags := data.toReadParams(ctx)
+	resp.Diagnostics.Append(diags...)
+	if resp.Diagnostics.HasError() {
+		return
+	}
+
+	res := new(http.Response)
+	env := R2DataCatalogResultDataSourceEnvelope{*data}
+	_, err := d.client.R2DataCatalog.Get(
+		ctx,
+		data.BucketName.ValueString(),
+		params,
+		option.WithResponseBodyInto(&res),
+		option.WithMiddleware(logging.Middleware(ctx)),
+	)
+	if err != nil {
+		resp.Diagnostics.AddError("failed to make http request", err.Error())
+		return
+	}
+	bytes, _ := io.ReadAll(res.Body)
+	err = apijson.UnmarshalComputed(bytes, &env)
+	if err != nil {
+		resp.Diagnostics.AddError("failed to deserialize http request", err.Error())
+		return
+	}
+	data = &env.Result
+	data.ID = data.BucketName
+
+	resp.Diagnostics.Append(resp.State.Set(ctx, &data)...)
+}

examples/resources/cloudflare_r2_data_catalog/resource.tf

@@ -0,0 +1,52 @@
+// File generated from our OpenAPI spec by Stainless. See CONTRIBUTING.md for details.
+
+package r2_data_catalog
+
+import (
+	"context"
+
+	"github.com/cloudflare/cloudflare-go/v6"
+	"github.com/cloudflare/cloudflare-go/v6/r2_data_catalog"
+	"github.com/cloudflare/terraform-provider-cloudflare/internal/customfield"
+	"github.com/hashicorp/terraform-plugin-framework/diag"
+	"github.com/hashicorp/terraform-plugin-framework/types"
+)
+
+type R2DataCatalogResultDataSourceEnvelope struct {
+	Result R2DataCatalogDataSourceModel `json:"result,computed"`
+}
+
+type R2DataCatalogDataSourceModel struct {
+	ID                types.String                                                            `tfsdk:"id" path:"bucket_name,computed"`
+	BucketName        types.String                                                            `tfsdk:"bucket_name" path:"bucket_name,required"`
+	AccountID         types.String                                                            `tfsdk:"account_id" path:"account_id,required"`
+	Bucket            types.String                                                            `tfsdk:"bucket" json:"bucket,computed"`
+	CredentialStatus  types.String                                                            `tfsdk:"credential_status" json:"credential_status,computed"`
+	Name              types.String                                                            `tfsdk:"name" json:"name,computed"`
+	Status            types.String                                                            `tfsdk:"status" json:"status,computed"`
+	MaintenanceConfig customfield.NestedObject[R2DataCatalogMaintenanceConfigDataSourceModel] `tfsdk:"maintenance_config" json:"maintenance_config,computed"`
+}
+
+func (m *R2DataCatalogDataSourceModel) toReadParams(_ context.Context) (params r2_data_catalog.R2DataCatalogGetParams, diags diag.Diagnostics) {
+	params = r2_data_catalog.R2DataCatalogGetParams{
+		AccountID: cloudflare.F(m.AccountID.ValueString()),
+	}
+
+	return
+}
+
+type R2DataCatalogMaintenanceConfigDataSourceModel struct {
+	Compaction         customfield.NestedObject[R2DataCatalogMaintenanceConfigCompactionDataSourceModel]         `tfsdk:"compaction" json:"compaction,computed"`
+	SnapshotExpiration customfield.NestedObject[R2DataCatalogMaintenanceConfigSnapshotExpirationDataSourceModel] `tfsdk:"snapshot_expiration" json:"snapshot_expiration,computed"`
+}
+
+type R2DataCatalogMaintenanceConfigCompactionDataSourceModel struct {
+	State        types.String `tfsdk:"state" json:"state,computed"`
+	TargetSizeMB types.String `tfsdk:"target_size_mb" json:"target_size_mb,computed"`
+}
+
+type R2DataCatalogMaintenanceConfigSnapshotExpirationDataSourceModel struct {
+	MaxSnapshotAge     types.String `tfsdk:"max_snapshot_age" json:"max_snapshot_age,computed"`
+	MinSnapshotsToKeep types.Int64  `tfsdk:"min_snapshots_to_keep" json:"min_snapshots_to_keep,computed"`
+	State              types.String `tfsdk:"state" json:"state,computed"`
+}