Stop default source and warehouse connections and upgrade Public API SDK

Author: deanhuynh

go.mod

@@ -11,7 +11,7 @@ require (
 	github.com/hashicorp/terraform-plugin-framework-validators v0.13.0
 	github.com/hashicorp/terraform-plugin-go v0.23.0
 	github.com/hashicorp/terraform-plugin-testing v1.10.0
-	github.com/segmentio/public-api-sdk-go v0.0.0-20240819211447-e2f7f9318028
+	github.com/segmentio/public-api-sdk-go v0.0.0-20240820210528-faf5e1da4b4a
 	gotest.tools/gotestsum v1.12.0
 )
 

go.sum

@@ -185,10 +185,10 @@ github.com/rogpeppe/go-internal v1.12.0 h1:exVL4IDcn6na9z1rAb56Vxr+CgyK3nn3O+epU
 github.com/rogpeppe/go-internal v1.12.0/go.mod h1:E+RYuTGaKKdloAfM02xzb0FW3Paa99yedzYV+kq4uf4=
 github.com/russross/blackfriday v1.6.0 h1:KqfZb0pUVN2lYqZUYRddxF4OR8ZMURnJIG5Y3VRLtww=
 github.com/russross/blackfriday v1.6.0/go.mod h1:ti0ldHuxg49ri4ksnFxlkCfN+hvslNlmVHqNRXXJNAY=
-github.com/segmentio/public-api-sdk-go v0.0.0-20231114153454-3be55fde5c99 h1:55dfJRsEeZLLFln+0gQ1pNZvalFMyeMV9nTPQwShkok=
-github.com/segmentio/public-api-sdk-go v0.0.0-20231114153454-3be55fde5c99/go.mod h1:1mLoKkR7t90unwNx7qx9PicO3AX5NflFD7ny3TvLExU=
-github.com/segmentio/public-api-sdk-go v0.0.0-20240819211447-e2f7f9318028 h1:mY+y1F+uVH9D2rGZDzrJf8fNaoGAWXMKNz857VYpc3k=
-github.com/segmentio/public-api-sdk-go v0.0.0-20240819211447-e2f7f9318028/go.mod h1:yKkoPfcOkkYjiZQj4lRWxji0Qwc6ncNEf7wCfywochY=
+github.com/segmentio/public-api-sdk-go v0.0.0-20240820173358-a52384e5ccc7 h1:04d9X+Bw1RY+lmbs0DajdA61xSQOZCAIUJuZfcFpz0g=
+github.com/segmentio/public-api-sdk-go v0.0.0-20240820173358-a52384e5ccc7/go.mod h1:yKkoPfcOkkYjiZQj4lRWxji0Qwc6ncNEf7wCfywochY=
+github.com/segmentio/public-api-sdk-go v0.0.0-20240820210528-faf5e1da4b4a h1:vSCltBxaOD5NRP3zGh/Xha3evkt0ZeXdAc6fTDTuwzg=
+github.com/segmentio/public-api-sdk-go v0.0.0-20240820210528-faf5e1da4b4a/go.mod h1:yKkoPfcOkkYjiZQj4lRWxji0Qwc6ncNEf7wCfywochY=
 github.com/sergi/go-diff v1.3.2-0.20230802210424-5b0b94c5c0d3 h1:n661drycOFuPLCN3Uc8sB6B/s6Z4t2xvBgU1htSHuq8=
 github.com/sergi/go-diff v1.3.2-0.20230802210424-5b0b94c5c0d3/go.mod h1:A0bzQcvG0E7Rwjx0REVgAGH58e96+X0MeOfepqsbeW4=
 github.com/shopspring/decimal v1.2.0/go.mod h1:DKyhrW/HYNuLGql+MJL6WCR6knT2jwCFRcu2hWCYk4o=

internal/provider/function_resource.go

@@ -159,7 +159,7 @@ func (r *functionResource) Create(ctx context.Context, req resource.CreateReques
 	resp.State.SetAttribute(ctx, path.Root("id"), function.Id)
 
 	var state models.FunctionState
-	state.Fill(api.Function(function))
+	state.Fill(api.FunctionV1(function))
 
 	// Destination functions append workspace name to display name causing inconsistency
 	if state.ResourceType.ValueString() == "DESTINATION" || state.ResourceType.ValueString() == "INSERT_DESTINATION" {
@@ -256,7 +256,7 @@ func (r *functionResource) Update(ctx context.Context, req resource.UpdateReques
 
 	function := out.Data.GetFunction()
 
-	state.Fill(api.Function(function))
+	state.Fill(api.FunctionV1(function))
 
 	// Destination functions append workspace name to display name causing inconsistency
 	if state.ResourceType.ValueString() == "DESTINATION" || state.ResourceType.ValueString() == "INSERT_DESTINATION" {

internal/provider/models/function.go

@@ -41,7 +41,7 @@ type FunctionPlan struct {
 	Settings          types.Set    `tfsdk:"settings"`
 }
 
-func (f *FunctionState) Fill(function api.Function) {
+func (f *FunctionState) Fill(function api.FunctionV1) {
 	f.ID = types.StringPointerValue(function.Id)
 	f.Code = types.StringPointerValue(function.Code)
 	f.DisplayName = types.StringPointerValue(function.DisplayName)

internal/provider/models/reverse_etl_model.go

@@ -27,7 +27,7 @@ func (r *ReverseETLModelState) Fill(model api.ReverseEtlModel) error {
 	r.ScheduleStrategy = types.StringValue(model.ScheduleStrategy)
 	r.Query = types.StringValue(model.Query)
 	r.QueryIdentifierColumn = types.StringValue(model.QueryIdentifierColumn)
-	scheduleConfig, err := GetSettings(model.ScheduleConfig)
+	scheduleConfig, err := GetScheduleConfig(model.ScheduleConfig)
 	if err != nil {
 		return err
 	}
@@ -39,3 +39,20 @@ func (r *ReverseETLModelState) Fill(model api.ReverseEtlModel) error {
 
 	return nil
 }
+
+func GetScheduleConfig(scheduleConfig api.NullableScheduleConfig) (jsontypes.Normalized, error) {
+	if !scheduleConfig.IsSet() {
+		return jsontypes.NewNormalizedNull(), nil
+	}
+
+	jsonScheduleConfigString, err := scheduleConfig.Get().MarshalJSON()
+	if err != nil {
+		return jsontypes.NewNormalizedNull(), err
+	}
+
+	if jsonScheduleConfigString == nil {
+		return jsontypes.NewNormalizedValue("{}"), nil
+	}
+
+	return jsontypes.NewNormalizedValue(string(jsonScheduleConfigString)), nil
+}