Ensure created resources are tainted properly upon failed applies (#99)

Author: deanhuynh

CHANGELOG.md

@@ -1,3 +1,6 @@
+## 0.10.3 (March 6, 2024)
+Correctly taints resources upon failed create to ensure resources are not duplicated.
+
 ## 0.10.2 (March 6, 2024)
 Fixes a rendering bug for `segment_profiles_warehouse` resource docs.
 

internal/provider/destination_filter_resource.go

@@ -166,6 +166,8 @@ func (r *destinationFilterResource) Create(ctx context.Context, req resource.Cre
 	}
 
 	destinationfilter := out.Data.Filter
+	resp.State.SetAttribute(ctx, path.Root("id"), destinationfilter.Id)
+	resp.State.SetAttribute(ctx, path.Root("destination_id"), destinationfilter.DestinationId)
 
 	var state models.DestinationFilterState
 	err = state.Fill(&destinationfilter)

internal/provider/destination_resource.go

@@ -549,6 +549,7 @@ func (r *destinationResource) Create(ctx context.Context, req resource.CreateReq
 
 		return
 	}
+	resp.State.SetAttribute(ctx, path.Root("id"), out.Data.Destination.Id)
 
 	var state models.DestinationState
 	err = state.Fill(&out.Data.Destination)

internal/provider/destination_subscription_resource.go

@@ -132,6 +132,8 @@ func (r *destinationSubscriptionResource) Create(ctx context.Context, req resour
 
 	destinationSubscription := out.Data.GetDestinationSubscription()
 
+	resp.State.SetAttribute(ctx, path.Root("id"), destinationSubscription.Id)
+
 	var state models.DestinationSubscriptionState
 	err = state.Fill(destinationSubscription)
 	if err != nil {

internal/provider/function_resource.go

@@ -156,6 +156,8 @@ func (r *functionResource) Create(ctx context.Context, req resource.CreateReques
 
 	function := out.Data.GetFunction()
 
+	resp.State.SetAttribute(ctx, path.Root("id"), function.Id)
+
 	var state models.FunctionState
 	state.Fill(api.Function(function))
 

internal/provider/insert_function_instance_resource.go

@@ -117,6 +117,8 @@ func (r *insertFunctionInstanceResource) Create(ctx context.Context, req resourc
 
 	insertFunctionInstance := out.Data.InsertFunctionInstance
 
+	resp.State.SetAttribute(ctx, path.Root("id"), insertFunctionInstance.Id)
+
 	var state models.InsertFunctionInstanceState
 	err = state.Fill(insertFunctionInstance)
 	if err != nil {

internal/provider/profiles_warehouse_resource.go

@@ -130,6 +130,9 @@ func (r *profilesWarehouseResource) Create(ctx context.Context, req resource.Cre
 
 	profilesWarehouse := out.Data.GetProfilesWarehouse()
 
+	resp.State.SetAttribute(ctx, path.Root("id"), profilesWarehouse.Id)
+	resp.State.SetAttribute(ctx, path.Root("space_id"), plan.SpaceID.ValueString())
+
 	var state models.ProfilesWarehouseState
 	err = state.Fill(profilesWarehouse)
 	if err != nil {

internal/provider/reverse_etl_model_resource.go

@@ -127,6 +127,8 @@ func (r *reverseETLModelResource) Create(ctx context.Context, req resource.Creat
 
 	reverseETLModel := out.Data.ReverseEtlModel
 
+	resp.State.SetAttribute(ctx, path.Root("id"), reverseETLModel.Id)
+
 	var state models.ReverseETLModelState
 	err = state.Fill(reverseETLModel)
 	if err != nil {

internal/provider/tracking_plan_resource.go

@@ -148,6 +148,8 @@ func (r *trackingPlanResource) Create(ctx context.Context, req resource.CreateRe
 
 	trackingPlan := out.Data.GetTrackingPlan()
 
+	resp.State.SetAttribute(ctx, path.Root("id"), trackingPlan.Id)
+
 	var rules []models.RulesState
 	plan.Rules.ElementsAs(ctx, &rules, false)
 

internal/provider/transformation_resource.go

@@ -178,6 +178,8 @@ func (r *transformationResource) Create(ctx context.Context, req resource.Create
 
 	transformation := out.Data.GetTransformation()
 
+	resp.State.SetAttribute(ctx, path.Root("id"), transformation.Id)
+
 	var state models.TransformationState
 	state.Fill(transformation)