feat(provider): introduce braze destination resource

Author: cysp

internal/provider/big_query_destination_resource.go

@@ -58,7 +58,7 @@ func (r *bigQueryDestinationResource) MoveState(ctx context.Context) []resource.
 		{
 			SourceSchema: &schema,
 			StateMover: func(_ context.Context, req resource.MoveStateRequest, resp *resource.MoveStateResponse) {
-				if req.SourceTypeName == "censusworkspace_destination" && req.SourceSchemaVersion == 0 {
+				if req.SourceTypeName == DestinationResourceTypeName && req.SourceSchemaVersion == 0 {
 					destinationModel := DestinationModel{}
 					resp.Diagnostics.Append(req.SourceState.Get(ctx, &destinationModel)...)
 

internal/provider/big_query_destination_resource_test.go

@@ -65,7 +65,7 @@ func TestAccBigQueryDestinationResourceImportNotFound(t *testing.T) {
 	})
 }
 
-//nolint:paralleltest
+//nolint:dupl,paralleltest
 func TestAccBigQueryDestinationResourceCreateUpdateDelete(t *testing.T) {
 	server, err := cmt.NewCensusManagementServer()
 	require.NoError(t, err)

internal/provider/braze_destination_connection_details_response.go

@@ -0,0 +1,41 @@
+package provider
+
+import (
+	"context"
+
+	"github.com/go-faster/jx"
+	"github.com/hashicorp/terraform-plugin-framework/diag"
+	"github.com/hashicorp/terraform-plugin-framework/path"
+)
+
+func NewBrazeDestinationConnectionDetailsFromResponse(_ context.Context, path path.Path, data jx.Raw) (TypedObject[BrazeDestinationConnectionDetails], diag.Diagnostics) {
+	if data == nil {
+		return NewTypedObjectNull[BrazeDestinationConnectionDetails](), nil
+	}
+
+	diags := diag.Diagnostics{}
+
+	var connectionDetails BrazeDestinationConnectionDetails
+
+	dec := jx.DecodeBytes(data)
+
+	err := connectionDetails.Decode(dec)
+	if err != nil {
+		diags.AddAttributeError(path, "Error decoding value", err.Error())
+	}
+
+	return NewTypedObject(connectionDetails), diags
+}
+
+func (cd *BrazeDestinationConnectionDetails) Decode(dec *jx.Decoder) error {
+	//nolint:wrapcheck
+	return dec.Obj(func(dec *jx.Decoder, key string) error {
+		switch key {
+		case "instance_url":
+			return JxDecodeStringValue(dec, &cd.InstanceURL)
+
+		default:
+			return dec.Skip()
+		}
+	})
+}

internal/provider/braze_destination_connection_details_response_test.go

@@ -0,0 +1,51 @@
+package provider_test
+
+import (
+	"testing"
+
+	. "github.com/cysp/terraform-provider-censusworkspace/internal/provider"
+	"github.com/hashicorp/terraform-plugin-framework/path"
+	"github.com/hashicorp/terraform-plugin-framework/types"
+	"github.com/stretchr/testify/assert"
+)
+
+func TestNewBrazeDestinationConnectionDetailsFromResponse(t *testing.T) {
+	t.Parallel()
+
+	testcases := map[string]struct {
+		input    []byte
+		expected TypedObject[BrazeDestinationConnectionDetails]
+	}{
+		"null": {
+			input:    nil,
+			expected: NewTypedObjectNull[BrazeDestinationConnectionDetails](),
+		},
+		"empty": {
+			input:    []byte(`{}`),
+			expected: NewTypedObject(BrazeDestinationConnectionDetails{}),
+		},
+		"instance_url": {
+			input: []byte(`{"instance_url":"instance-url"}`),
+			expected: NewTypedObject(BrazeDestinationConnectionDetails{
+				InstanceURL: types.StringValue("instance-url"),
+			}),
+		},
+		"instance_url=null": {
+			input: []byte(`{"instance_url":null}`),
+			expected: NewTypedObject(BrazeDestinationConnectionDetails{
+				InstanceURL: types.StringNull(),
+			}),
+		},
+	}
+
+	for name, testcase := range testcases {
+		t.Run(name, func(t *testing.T) {
+			t.Parallel()
+
+			actual, diags := NewBrazeDestinationConnectionDetailsFromResponse(t.Context(), path.Root("connection_details"), testcase.input)
+			assert.Empty(t, diags)
+
+			assert.Equal(t, testcase.expected, actual)
+		})
+	}
+}

internal/provider/braze_destination_credentials.go

@@ -0,0 +1,5 @@
+package provider
+
+func (c *BrazeDestinationCredentials) UpdateWithConnectionDetails(connectionDetails BrazeDestinationConnectionDetails) {
+	c.InstanceURL = connectionDetails.InstanceURL
+}

internal/provider/braze_destination_model.go

@@ -0,0 +1,27 @@
+package provider
+
+import (
+	"github.com/hashicorp/terraform-plugin-framework/types"
+)
+
+const (
+	BrazeDestinationType = "braze"
+)
+
+type BrazeDestinationModel struct {
+	destinationModelBase
+
+	Credentials       TypedObject[BrazeDestinationCredentials]       `tfsdk:"credentials"`
+	ConnectionDetails TypedObject[BrazeDestinationConnectionDetails] `tfsdk:"connection_details"`
+}
+
+//nolint:recvcheck
+type BrazeDestinationCredentials struct {
+	InstanceURL types.String `tfsdk:"instance_url"`
+	APIKey      types.String `tfsdk:"api_key"`
+	ClientKey   types.String `tfsdk:"client_key"`
+}
+
+type BrazeDestinationConnectionDetails struct {
+	InstanceURL types.String `tfsdk:"instance_url"`
+}

internal/provider/braze_destination_model_request.go

@@ -0,0 +1,74 @@
+package provider
+
+import (
+	"context"
+
+	cm "github.com/cysp/terraform-provider-censusworkspace/internal/census-management-go"
+	"github.com/go-faster/jx"
+	"github.com/hashicorp/terraform-plugin-framework/diag"
+	"github.com/hashicorp/terraform-plugin-framework/path"
+)
+
+func (m *BrazeDestinationModel) ToCreateDestinationData(_ context.Context) (cm.CreateDestinationBody, diag.Diagnostics) {
+	diags := diag.Diagnostics{}
+
+	body := cm.CreateDestinationBody{
+		ServiceConnection: cm.CreateDestinationBodyServiceConnection{
+			Name: m.Name.ValueString(),
+			Type: BrazeDestinationType,
+		},
+	}
+
+	enc := jx.Encoder{}
+	if !m.Credentials.IsNull() && !m.Credentials.IsUnknown() {
+		credentialsEncodeFailed := m.Credentials.Value().Encode(&enc)
+		if credentialsEncodeFailed {
+			diags.AddAttributeError(path.Root("credentials"), "Failed to encode value", "")
+		}
+
+		body.ServiceConnection.Credentials = enc.Bytes()
+	}
+
+	return body, diags
+}
+
+func (m *BrazeDestinationModel) ToUpdateDestinationData(_ context.Context) (cm.UpdateDestinationBody, diag.Diagnostics) {
+	diags := diag.Diagnostics{}
+
+	body := cm.UpdateDestinationBody{
+		ServiceConnection: cm.UpdateDestinationBodyServiceConnection{
+			Name: cm.NewOptString(m.Name.ValueString()),
+		},
+	}
+
+	enc := jx.Encoder{}
+	if !m.Credentials.IsNull() && !m.Credentials.IsUnknown() {
+		credentialsEncodeFailed := m.Credentials.Value().Encode(&enc)
+		if credentialsEncodeFailed {
+			diags.AddAttributeError(path.Root("credentials"), "Failed to encode value", "")
+		}
+
+		body.ServiceConnection.Credentials = enc.Bytes()
+	}
+
+	return body, diags
+}
+
+func (c BrazeDestinationCredentials) Encode(enc *jx.Encoder) bool {
+	return enc.Obj(func(enc *jx.Encoder) {
+		enc.Field("instance_url", func(e *jx.Encoder) {
+			e.Str(c.InstanceURL.ValueString())
+		})
+
+		enc.Field("api_key", func(e *jx.Encoder) {
+			e.Str(c.APIKey.ValueString())
+		})
+
+		clientKey := c.ClientKey.ValueString()
+		if clientKey != "" {
+			enc.Field("client_key", func(e *jx.Encoder) {
+				e.Str(clientKey)
+			})
+		}
+	})
+}

internal/provider/braze_destination_model_response.go

@@ -0,0 +1,46 @@
+//nolint:dupl
+package provider
+
+import (
+	"context"
+	"strconv"
+
+	cm "github.com/cysp/terraform-provider-censusworkspace/internal/census-management-go"
+	"github.com/hashicorp/terraform-plugin-framework-timetypes/timetypes"
+	"github.com/hashicorp/terraform-plugin-framework/diag"
+	"github.com/hashicorp/terraform-plugin-framework/path"
+	"github.com/hashicorp/terraform-plugin-framework/types"
+)
+
+func NewBrazeDestinationModelFromResponse(ctx context.Context, response cm.DestinationData) (BrazeDestinationModel, diag.Diagnostics) {
+	diags := diag.Diagnostics{}
+
+	path := path.Empty()
+
+	model := BrazeDestinationModel{
+		destinationModelBase: destinationModelBase{
+			ID:        types.StringValue(strconv.FormatInt(response.ID, 10)),
+			Name:      types.StringValue(response.Name),
+			CreatedAt: timetypes.NewRFC3339TimeValue(response.CreatedAt),
+		},
+	}
+
+	if response.ConnectionDetails != nil {
+		path := path.AtName("connection_details")
+
+		connectionDetails, connectionDetailsDiags := NewBrazeDestinationConnectionDetailsFromResponse(ctx, path, response.ConnectionDetails)
+		diags.Append(connectionDetailsDiags...)
+
+		model.ConnectionDetails = connectionDetails
+	}
+
+	if lastTestedAt, lastTestedAtOk := response.LastTestedAt.Get(); lastTestedAtOk {
+		model.LastTestedAt = timetypes.NewRFC3339TimeValue(lastTestedAt)
+	}
+
+	if lastTestSucceeded, lastTestSucceededOk := response.LastTestSucceeded.Get(); lastTestSucceededOk {
+		model.LastTestSucceeded = types.BoolValue(lastTestSucceeded)
+	}
+
+	return model, diags
+}