Profiles warehouse resource (#59)

Author: deanhuynh

docs/resources/profiles_warehouse.md

@@ -0,0 +1,54 @@
+---
+# generated by https://github.com/hashicorp/terraform-plugin-docs
+page_title: "segment_profiles_warehouse Resource - terraform-provider-segment"
+subcategory: ""
+description: |-
+  A Profiles Sync Warehouse is a central repository of data collected from your workspace. It is what commonly comes to mind when you think about a relational database: structured data that fits into rows and columns.
+      To import a Profiles Warehouse into Terraform, use the following format: 'space-id:warehouse-id'
+---
+
+# segment_profiles_warehouse (Resource)
+
+A Profiles Sync Warehouse is a central repository of data collected from your workspace. It is what commonly comes to mind when you think about a relational database: structured data that fits into rows and columns.
+		
+		To import a Profiles Warehouse into Terraform, use the following format: 'space-id:warehouse-id'
+
+## Example Usage
+
+```terraform
+# Configures a specific profiles sync warehouse
+resource "segment_profiles_warehouse" "example" {
+  space_id    = "cba321"
+  metadata_id = "abc123"
+  enabled     = true
+  settings = jsonencode({
+    token : "zyx321"
+  })
+  name = "My Terraform Warehouse!"
+}
+```
+
+<!-- schema generated by tfplugindocs -->
+## Schema
+
+### Required
+
+- `metadata_id` (String) The Warehouse metadata to use.
+- `settings` (String) A key-value object that contains instance-specific settings for a Warehouse.
+			
+			 Different kinds of Warehouses require different settings. The required and optional settings
+			 for a Warehouse are described in the 'options' object of the associated Warehouse metadata.
+			
+			 You can find the full list of Warehouse metadata and related settings information in the
+			 '/catalog/warehouses' endpoint.
+- `space_id` (String) The Space id.
+
+### Optional
+
+- `enabled` (Boolean) Enable to allow this Warehouse to receive data. Defaults to true.
+- `name` (String) An optional human-readable name for this Warehouse.
+- `schema_name` (String) The custom schema name that Segment uses on the Warehouse side. The space slug value is default otherwise.
+
+### Read-Only
+
+- `id` (String) The id of the Warehouse.

examples/resources/segment_profiles_warehouse/resource.tf

@@ -0,0 +1,10 @@
+# Configures a specific profiles sync warehouse
+resource "segment_profiles_warehouse" "example" {
+  space_id    = "cba321"
+  metadata_id = "abc123"
+  enabled     = true
+  settings = jsonencode({
+    token : "zyx321"
+  })
+  name = "My Terraform Warehouse!"
+}

internal/provider/destination_data_source.go

@@ -81,7 +81,7 @@ func (d *destinationDataSource) Read(ctx context.Context, req datasource.ReadReq
 	}
 	if err != nil {
 		resp.Diagnostics.AddError(
-			"Unable to Read Destination",
+			"Unable to read Destination",
 			getError(err, body),
 		)
 
@@ -93,7 +93,7 @@ func (d *destinationDataSource) Read(ctx context.Context, req datasource.ReadReq
 	err = state.Fill(&destination)
 	if err != nil {
 		resp.Diagnostics.AddError(
-			"Unable to Read Destination",
+			"Unable to populate Destination state",
 			err.Error(),
 		)
 

internal/provider/destination_filter_resource.go

@@ -54,6 +54,9 @@ func (r *destinationFilterResource) Schema(_ context.Context, _ resource.SchemaR
 			"id": schema.StringAttribute{
 				Computed:    true,
 				Description: "The unique id of this filter.",
+				PlanModifiers: []planmodifier.String{
+					stringplanmodifier.UseStateForUnknown(),
+				},
 			},
 			"if": schema.StringAttribute{
 				Required:    true,

internal/provider/destination_metadata_data_source.go

@@ -401,7 +401,7 @@ func (d *destinationMetadataDataSource) Read(ctx context.Context, req datasource
 	}
 	if err != nil {
 		resp.Diagnostics.AddError(
-			"Unable to Read Source metadata",
+			"Unable to read Source metadata",
 			getError(err, body),
 		)
 
@@ -412,7 +412,7 @@ func (d *destinationMetadataDataSource) Read(ctx context.Context, req datasource
 	err = state.Fill(destinationMetadata)
 	if err != nil {
 		resp.Diagnostics.AddError(
-			"Unable to Read Source metadata",
+			"Unable to read Source metadata",
 			err.Error(),
 		)
 

internal/provider/destination_resource.go

@@ -554,7 +554,7 @@ func (r *destinationResource) Create(ctx context.Context, req resource.CreateReq
 	err = state.Fill(&destination)
 	if err != nil {
 		resp.Diagnostics.AddError(
-			"Unable to create Destination",
+			"Unable to populate Destination state",
 			err.Error(),
 		)
 
@@ -600,7 +600,7 @@ func (r *destinationResource) Read(ctx context.Context, req resource.ReadRequest
 	err = state.Fill(&destination)
 	if err != nil {
 		resp.Diagnostics.AddError(
-			"Unable to read Destination",
+			"Unable to populate Destination state",
 			err.Error(),
 		)
 
@@ -662,7 +662,7 @@ func (r *destinationResource) Update(ctx context.Context, req resource.UpdateReq
 	err = state.Fill(&destination)
 	if err != nil {
 		resp.Diagnostics.AddError(
-			"Unable to update Destination",
+			"Unable to populate Destination state",
 			err.Error(),
 		)
 
@@ -696,7 +696,8 @@ func (r *destinationResource) Delete(ctx context.Context, req resource.DeleteReq
 	}
 	if err != nil {
 		resp.Diagnostics.AddError(
-			"Error deleting Destination", "Could not delete Destination, unexpected error: "+getError(err, body),
+			"Unable to delete Destination",
+			getError(err, body),
 		)
 
 		return

internal/provider/label_resource.go

@@ -107,17 +107,16 @@ func (r *labelResource) Create(ctx context.Context, req resource.CreateRequest,
 	}
 	if err != nil {
 		resp.Diagnostics.AddError(
-			"Unable to create a label",
+			"Unable to create Label",
 			getError(err, body),
 		)
 
 		return
 	}
 
 	outLabel := out.Data.Label
-	plan.Key = types.StringValue(outLabel.Key)
-	plan.Value = types.StringValue(outLabel.Value)
-	plan.Description = types.StringPointerValue(outLabel.Description)
+	var state models.LabelState
+	state.Fill(api.LabelV1(outLabel))
 
 	// Set state to fully populated data
 	diags = resp.State.Set(ctx, plan)
@@ -150,15 +149,27 @@ func (r *labelResource) Read(ctx context.Context, req resource.ReadRequest, resp
 
 	labels := response.Data.Labels
 
-	label := api.LabelV1{}
+	var label *api.LabelV1
 	for _, l := range labels {
 		if l.Key == types.String.ValueString(state.Key) && l.Value == types.String.ValueString(state.Value) {
-			label = l
+			label = &api.LabelV1{
+				Key:         l.Key,
+				Value:       l.Value,
+				Description: l.Description,
+			}
 		}
 	}
 
-	state.Key = types.StringValue(label.Key)
-	state.Value = types.StringValue(label.Value)
+	if label == nil {
+		resp.Diagnostics.AddError(
+			"Unable to find Label",
+			fmt.Sprintf("Unable to find Label with key: %q and value: %q", state.Key, state.Value),
+		)
+
+		return
+	}
+
+	state.Fill(*label)
 	if label.Description != nil && *label.Description == "" {
 		label.Description = nil
 	}

internal/provider/models/profiles_warehouse.go

@@ -0,0 +1,41 @@
+package models
+
+import (
+	"github.com/hashicorp/terraform-plugin-framework-jsontypes/jsontypes"
+	"github.com/hashicorp/terraform-plugin-framework/types"
+	"github.com/segmentio/public-api-sdk-go/api"
+)
+
+type ProfilesWarehouseState struct {
+	ID         types.String         `tfsdk:"id"`
+	SpaceID    types.String         `tfsdk:"space_id"`
+	MetadataID types.String         `tfsdk:"metadata_id"`
+	Name       types.String         `tfsdk:"name"`
+	Enabled    types.Bool           `tfsdk:"enabled"`
+	SchemaName types.String         `tfsdk:"schema_name"`
+	Settings   jsontypes.Normalized `tfsdk:"settings"`
+}
+
+func (w *ProfilesWarehouseState) Fill(warehouse api.ProfilesWarehouse1) error {
+	w.ID = types.StringValue(warehouse.Id)
+	w.SpaceID = types.StringValue(warehouse.SpaceId)
+	w.MetadataID = types.StringValue(warehouse.Metadata.Id)
+	if warehouse.Settings.IsSet() {
+		name := warehouse.Settings.Get().Get()["name"]
+		if name != nil {
+			stringName, ok := name.(string)
+			if ok {
+				w.Name = types.StringValue(stringName)
+			}
+		}
+	}
+	w.Enabled = types.BoolValue(warehouse.Enabled)
+	w.SchemaName = types.StringPointerValue(warehouse.SchemaName)
+	settings, err := GetSettings(warehouse.Settings)
+	if err != nil {
+		return err
+	}
+	w.Settings = settings
+
+	return nil
+}

internal/provider/models/source.go

@@ -45,7 +45,7 @@ func (s *SourceState) Fill(source api.Source4) error {
 	if err != nil {
 		return err
 	}
-	settings, err := s.getSettings(source.Settings)
+	settings, err := GetSettings(source.Settings)
 	if err != nil {
 		return err
 	}
@@ -77,7 +77,7 @@ func (s *SourceState) getWriteKeys(writeKeys []string) []types.String {
 	return writeKeysToAdd
 }
 
-func (s *SourceState) getSettings(settings api.NullableModelMap) (jsontypes.Normalized, error) {
+func GetSettings(settings api.NullableModelMap) (jsontypes.Normalized, error) {
 	if !settings.IsSet() {
 		return jsontypes.NewNormalizedNull(), nil
 	}