Reverse ETL model resource (#63)

Co-authored-by: Marcelo Vargas <[email protected]>

Author: deanhuynh

docs/resources/reverse_etl_model.md

@@ -0,0 +1,49 @@
+---
+# generated by https://github.com/hashicorp/terraform-plugin-docs
+page_title: "segment_reverse_etl_model Resource - terraform-provider-segment"
+subcategory: ""
+description: |-
+  
+---
+
+# segment_reverse_etl_model (Resource)
+
+
+
+## Example Usage
+
+```terraform
+# Configures a specific Reverse ETL model
+resource "segment_reverse_etl_model" "example" {
+  source_id               = segment_source.javascript.id
+  name                    = "Example Reverse ETL model"
+  enabled                 = true
+  description             = "Example Reverse ETL model"
+  schedule_strategy       = "SPECIFIC_DAYS"
+  query                   = "SELECT good_stuff FROM stuff"
+  query_identifier_column = "good_stuff"
+  schedule_config = jsonencode({
+    "days" : [0, 1, 2, 3],
+    "hours" : [0, 1, 3],
+    "timezone" : "America/Los_Angeles"
+  })
+}
+```
+
+<!-- schema generated by tfplugindocs -->
+## Schema
+
+### Required
+
+- `description` (String) A longer, more descriptive explanation of the Model.
+- `enabled` (Boolean) Indicates whether the Model should have syncs enabled. When disabled, no syncs will be triggered, regardless of the enabled status of the attached destinations/subscriptions.
+- `name` (String) A short, human-readable description of the Model.
+- `query` (String) The SQL query that will be executed to extract data from the connected Source.
+- `query_identifier_column` (String) Indicates the column named in `query` that should be used to uniquely identify the extracted records.
+- `schedule_config` (String) Depending on the chosen strategy, configures the schedule for this model.
+- `schedule_strategy` (String) Determines the strategy used for triggering syncs, which will be used in conjunction with scheduleConfig.
+- `source_id` (String) Indicates which Source to attach this model to.
+
+### Read-Only
+
+- `id` (String) The unique identifier for the model.

examples/resources/segment_reverse_etl_model/resource.tf

@@ -0,0 +1,15 @@
+# Configures a specific Reverse ETL model
+resource "segment_reverse_etl_model" "example" {
+  source_id               = segment_source.javascript.id
+  name                    = "Example Reverse ETL model"
+  enabled                 = true
+  description             = "Example Reverse ETL model"
+  schedule_strategy       = "SPECIFIC_DAYS"
+  query                   = "SELECT good_stuff FROM stuff"
+  query_identifier_column = "good_stuff"
+  schedule_config = jsonencode({
+    "days" : [0, 1, 2, 3],
+    "hours" : [0, 1, 3],
+    "timezone" : "America/Los_Angeles"
+  })
+}

internal/provider/models/reverse_etl_model.go

@@ -0,0 +1,37 @@
+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 ReverseETLModelState struct {
+	ID                    types.String         `tfsdk:"id"`
+	SourceID              types.String         `tfsdk:"source_id"`
+	Name                  types.String         `tfsdk:"name"`
+	Description           types.String         `tfsdk:"description"`
+	Enabled               types.Bool           `tfsdk:"enabled"`
+	ScheduleStrategy      types.String         `tfsdk:"schedule_strategy"`
+	Query                 types.String         `tfsdk:"query"`
+	QueryIdentifierColumn types.String         `tfsdk:"query_identifier_column"`
+	ScheduleConfig        jsontypes.Normalized `tfsdk:"schedule_config"`
+}
+
+func (r *ReverseETLModelState) Fill(model api.ReverseEtlModel) error {
+	r.ID = types.StringValue(model.Id)
+	r.SourceID = types.StringValue(model.SourceId)
+	r.Name = types.StringValue(model.Name)
+	r.Description = types.StringValue(model.Description)
+	r.Enabled = types.BoolValue(model.Enabled)
+	r.ScheduleStrategy = types.StringValue(model.ScheduleStrategy)
+	r.Query = types.StringValue(model.Query)
+	r.QueryIdentifierColumn = types.StringValue(model.QueryIdentifierColumn)
+	scheduleConfig, err := GetSettings(model.ScheduleConfig)
+	if err != nil {
+		return err
+	}
+	r.ScheduleConfig = scheduleConfig
+
+	return nil
+}

internal/provider/provider.go

@@ -155,6 +155,7 @@ func (p *segmentProvider) Resources(_ context.Context) []func() resource.Resourc
 		NewProfilesWarehouseResource,
 		NewDestinationSubscriptionResource,
 		NewSourceTrackingPlanConnectionResource,
+		NewReverseETLModelResource,
 	}
 }