Refac/stackittpr 791 use unchanged paths

stackit/internal/services/sfs/resourcepool/resource.go

@@ -237,7 +237,10 @@ func (r *resourcePoolResource) Schema(_ context.Context, _ resource.SchemaReques
 						Description: "Name of the snapshot policy.",
 						Computed:    true,
 						PlanModifiers: []planmodifier.String{
-							stringplanmodifierUtils.UseStateForUnknownIf(stringplanmodifierUtils.StringUnchanged(path.Root("snapshot_policy").AtName("id")), "sets `UseStateForUnknown` only if `id` has not changed"),
+							stringplanmodifierUtils.UseStateForUnknownIf(
+								stringplanmodifierUtils.UnchangedPaths(path.MatchRoot("snapshot_policy").AtName("id")),
+								"sets `UseStateForUnknown` only if `id` has not changed",
+							),
 						},
 					},
 				},

stackit/internal/services/ske/cluster/resource.go

@@ -489,7 +489,10 @@ func (r *clusterResource) Schema(_ context.Context, _ resource.SchemaRequest, re
 				Description: "Full Kubernetes version used. For example, if 1.22 was set in `kubernetes_version_min`, this value may result to 1.22.15. " + SKEUpdateDoc,
 				Computed:    true,
 				PlanModifiers: []planmodifier.String{
-					stringplanmodifierUtils.UseStateForUnknownIf(stringplanmodifierUtils.StringUnchanged(path.Root("kubernetes_version_min")), "sets `UseStateForUnknown` only if `kubernetes_min_version` has not changed"),
+					stringplanmodifierUtils.UseStateForUnknownIf(
+						stringplanmodifierUtils.UnchangedPaths(path.MatchRoot("kubernetes_version_min")),
+						"sets `UseStateForUnknown` only if `kubernetes_min_version` has not changed",
+					),
 				},
 			},
 			"egress_address_ranges": schema.ListAttribute{
@@ -580,7 +583,10 @@ func (r *clusterResource) Schema(_ context.Context, _ resource.SchemaRequest, re
 							Description: "Full OS image version used. For example, if 3815.2 was set in `os_version_min`, this value may result to 3815.2.2. " + SKEUpdateDoc,
 							Computed:    true,
 							PlanModifiers: []planmodifier.String{
-								stringplanmodifierUtils.UseStateForUnknownIf(skeUtils.HasOsVersionMinChanged, "sets `UseStateForUnknown` only if `os_version_min` has not changed"), //nolint:staticcheck // temporary fix for issue with StringUnchanged
+								stringplanmodifierUtils.UseStateForUnknownIf(
+									stringplanmodifierUtils.UnchangedPaths(path.MatchRelative().AtParent().AtName("os_version_min")),
+									"sets `UseStateForUnknown` only if `os_version_min` has not changed",
+								),
 							},
 						},
 						"volume_type": schema.StringAttribute{

stackit/internal/services/ske/ske_acc_test.go

@@ -23,6 +23,8 @@ import (
 	"github.com/stackitcloud/terraform-provider-stackit/stackit/internal/testutil"
 )
 
+const ephemeralKubeconfigAddress = "ephemeral.stackit_ske_kubeconfig.ephemeral_kubeconfig"
+
 var (
 	minTestName = "acc-min" + acctest.RandStringFromCharSet(3, acctest.CharSetAlpha)
 	maxTestName = "acc-max" + acctest.RandStringFromCharSet(3, acctest.CharSetAlpha)
@@ -138,6 +140,11 @@ func TestAccSKEMin(t *testing.T) {
 			{
 				Config:          testutil.NewConfigBuilder().Experiments(testutil.ExperimentSKE).BuildProviderConfig() + "\n" + resourceMin,
 				ConfigVariables: testConfigVarsMin,
+				ConfigPlanChecks: resource.ConfigPlanChecks{
+					PostApplyPreRefresh:  []plancheck.PlanCheck{testutil.ExpectOnlyEphemeralOpen(ephemeralKubeconfigAddress)},
+					PostApplyPostRefresh: []plancheck.PlanCheck{testutil.ExpectOnlyEphemeralOpen(ephemeralKubeconfigAddress)},
+				},
+				ExpectNonEmptyPlan: testutil.UsingOpenTofu(),
 				Check: resource.ComposeAggregateTestCheckFunc(
 					// cluster data
 					resource.TestCheckResourceAttr("stackit_ske_cluster.cluster", "project_id", testutil.ConvertConfigVariable(testConfigVarsMin["project_id"])),
@@ -189,6 +196,11 @@ func TestAccSKEMin(t *testing.T) {
 			{
 				Config:          testutil.NewConfigBuilder().Experiments(testutil.ExperimentSKE).BuildProviderConfig() + "\n" + resourceMin,
 				ConfigVariables: testConfigVarsMin,
+				ConfigPlanChecks: resource.ConfigPlanChecks{
+					PostApplyPreRefresh:  []plancheck.PlanCheck{testutil.ExpectOnlyEphemeralOpen(ephemeralKubeconfigAddress)},
+					PostApplyPostRefresh: []plancheck.PlanCheck{testutil.ExpectOnlyEphemeralOpen(ephemeralKubeconfigAddress)},
+				},
+				ExpectNonEmptyPlan: testutil.UsingOpenTofu(),
 				Check: resource.ComposeAggregateTestCheckFunc(
 
 					// cluster data
@@ -247,7 +259,10 @@ func TestAccSKEMin(t *testing.T) {
 					PreApply: []plancheck.PlanCheck{
 						plancheck.ExpectResourceAction("stackit_ske_cluster.cluster", plancheck.ResourceActionUpdate),
 					},
+					PostApplyPreRefresh:  []plancheck.PlanCheck{testutil.ExpectOnlyEphemeralOpen(ephemeralKubeconfigAddress)},
+					PostApplyPostRefresh: []plancheck.PlanCheck{testutil.ExpectOnlyEphemeralOpen(ephemeralKubeconfigAddress)},
 				},
+				ExpectNonEmptyPlan: testutil.UsingOpenTofu(),
 				Check: resource.ComposeAggregateTestCheckFunc(
 					// cluster data
 					resource.TestCheckResourceAttr("stackit_ske_cluster.cluster", "project_id", testutil.ConvertConfigVariable(configVarsMinUpdated()["project_id"])),
@@ -299,6 +314,11 @@ func TestAccSKEMax(t *testing.T) {
 			{
 				Config:          testutil.NewConfigBuilder().Experiments(testutil.ExperimentSKE).BuildProviderConfig() + "\n" + resourceMax,
 				ConfigVariables: testConfigVarsMax,
+				ConfigPlanChecks: resource.ConfigPlanChecks{
+					PostApplyPreRefresh:  []plancheck.PlanCheck{testutil.ExpectOnlyEphemeralOpen(ephemeralKubeconfigAddress)},
+					PostApplyPostRefresh: []plancheck.PlanCheck{testutil.ExpectOnlyEphemeralOpen(ephemeralKubeconfigAddress)},
+				},
+				ExpectNonEmptyPlan: testutil.UsingOpenTofu(),
 				Check: resource.ComposeAggregateTestCheckFunc(
 					// cluster data
 					resource.TestCheckResourceAttr("stackit_ske_cluster.cluster", "project_id", testutil.ConvertConfigVariable(testConfigVarsMax["project_id"])),
@@ -389,6 +409,11 @@ func TestAccSKEMax(t *testing.T) {
 			{
 				Config:          testutil.NewConfigBuilder().Experiments(testutil.ExperimentSKE).BuildProviderConfig() + "\n" + resourceMax,
 				ConfigVariables: testConfigVarsMax,
+				ConfigPlanChecks: resource.ConfigPlanChecks{
+					PostApplyPreRefresh:  []plancheck.PlanCheck{testutil.ExpectOnlyEphemeralOpen(ephemeralKubeconfigAddress)},
+					PostApplyPostRefresh: []plancheck.PlanCheck{testutil.ExpectOnlyEphemeralOpen(ephemeralKubeconfigAddress)},
+				},
+				ExpectNonEmptyPlan: testutil.UsingOpenTofu(),
 				Check: resource.ComposeAggregateTestCheckFunc(
 
 					// cluster data
@@ -486,7 +511,10 @@ func TestAccSKEMax(t *testing.T) {
 					PreApply: []plancheck.PlanCheck{
 						plancheck.ExpectResourceAction("stackit_ske_cluster.cluster", plancheck.ResourceActionUpdate),
 					},
+					PostApplyPreRefresh:  []plancheck.PlanCheck{testutil.ExpectOnlyEphemeralOpen(ephemeralKubeconfigAddress)},
+					PostApplyPostRefresh: []plancheck.PlanCheck{testutil.ExpectOnlyEphemeralOpen(ephemeralKubeconfigAddress)},
 				},
+				ExpectNonEmptyPlan: testutil.UsingOpenTofu(),
 				Check: resource.ComposeAggregateTestCheckFunc(
 					// cluster data
 					resource.TestCheckResourceAttr("stackit_ske_cluster.cluster", "project_id", testutil.ConvertConfigVariable(configVarsMaxUpdated()["project_id"])),

stackit/internal/services/ske/utils/util.go

@@ -5,14 +5,11 @@ import (
 	"fmt"
 
 	"github.com/hashicorp/terraform-plugin-framework/diag"
-	"github.com/hashicorp/terraform-plugin-framework/resource/schema/planmodifier"
-	"github.com/hashicorp/terraform-plugin-framework/types"
 	"github.com/stackitcloud/stackit-sdk-go/core/config"
 	ske "github.com/stackitcloud/stackit-sdk-go/services/ske/v2api"
 
 	"github.com/stackitcloud/terraform-provider-stackit/stackit/internal/core"
 	"github.com/stackitcloud/terraform-provider-stackit/stackit/internal/utils"
-	"github.com/stackitcloud/terraform-provider-stackit/stackit/internal/utils/planmodifiers/stringplanmodifier"
 )
 
 func ConfigureClient(ctx context.Context, providerData *core.ProviderData, diags *diag.Diagnostics) *ske.APIClient {
@@ -45,27 +42,3 @@ func IsEmptyExtension(extension *ske.Extension) bool {
 	}
 	return false
 }
-
-// Deprecated: HasOsVersionMinChanged
-func HasOsVersionMinChanged(ctx context.Context, request planmodifier.StringRequest, response *stringplanmodifier.UseStateForUnknownFuncResponse) { // nolint:gocritic // function signature required by Terraform
-	dependencyPath := request.Path.ParentPath().AtName("os_version_min")
-
-	var minVersionPlan types.String
-	diags := request.Plan.GetAttribute(ctx, dependencyPath, &minVersionPlan)
-	response.Diagnostics.Append(diags...)
-	if response.Diagnostics.HasError() {
-		return
-	}
-
-	var minVersionState types.String
-	diags = request.State.GetAttribute(ctx, dependencyPath, &minVersionState)
-	response.Diagnostics.Append(diags...)
-	if response.Diagnostics.HasError() {
-		return
-	}
-
-	if minVersionState == minVersionPlan {
-		response.UseStateForUnknown = true
-		return
-	}
-}

stackit/internal/testutil/plancheck.go

@@ -0,0 +1,45 @@
+package testutil
+
+import (
+	"context"
+	"fmt"
+	"slices"
+
+	"github.com/hashicorp/terraform-plugin-testing/plancheck"
+)
+
+// ExpectOnlyEphemeralOpen returns a plan check that allows no-op actions and
+// OpenTofu "open" actions for the given ephemeral resource addresses.
+func ExpectOnlyEphemeralOpen(configAddresses ...string) plancheck.PlanCheck {
+	return expectOnlyEphemeralOpen{configAddresses: configAddresses}
+}
+
+type expectOnlyEphemeralOpen struct {
+	configAddresses []string
+}
+
+func (c expectOnlyEphemeralOpen) CheckPlan(_ context.Context, req plancheck.CheckPlanRequest, resp *plancheck.CheckPlanResponse) {
+	for _, resourceChange := range req.Plan.ResourceChanges {
+		if resourceChange.Change == nil || resourceChange.Change.Actions.NoOp() {
+			continue
+		}
+
+		actions := resourceChange.Change.Actions
+		isSpecificResource := slices.Contains(c.configAddresses, resourceChange.Address)
+		if isSpecificResource &&
+			string(resourceChange.Mode) == "ephemeral" &&
+			len(actions) == 1 && string(actions[0]) == "open" {
+			continue
+		}
+
+		resp.Error = fmt.Errorf("unexpected planned action(s) %v for %s", actions, resourceChange.Address)
+		return
+	}
+
+	for name, outputChange := range req.Plan.OutputChanges {
+		if outputChange != nil && !outputChange.Actions.NoOp() {
+			resp.Error = fmt.Errorf("unexpected planned action(s) %v for output %s", outputChange.Actions, name)
+			return
+		}
+	}
+}