Operation lifecycle operation continue on HTTP 409 responses (#719)

* feat: enhance lifecycle operation handling by adding support for HTTP 409 Conflict status

* feat: add lifecycle operation support for HTTP 409 responses

---------

Co-authored-by: github-actions[bot] <tfmod442916@users.noreply.github.com>

Author: mawasile

.changes/unreleased/added-20250424-132557.yaml

@@ -0,0 +1,5 @@
+kind: added
+body: Operation lifecycle operation continue on HTTP 409 responses
+time: 2025-04-24T13:25:57.572972549Z
+custom:
+    Issue: "719"

internal/api/lifecycle.go

@@ -66,7 +66,7 @@ func (client *Client) DoWaitForLifecycleOperationStatus(ctx context.Context, res
 
 	for {
 		lifecycleResponse := LifecycleDto{}
-		response, err = client.Execute(ctx, nil, "GET", locationHeader, nil, nil, []int{http.StatusOK}, &lifecycleResponse)
+		response, err = client.Execute(ctx, nil, "GET", locationHeader, nil, nil, []int{http.StatusOK, http.StatusConflict}, &lifecycleResponse)
 		if err != nil {
 			return nil, err
 		}
@@ -76,8 +76,11 @@ func (client *Client) DoWaitForLifecycleOperationStatus(ctx context.Context, res
 			return nil, err
 		}
 
-		tflog.Debug(ctx, "Lifecycle Operation State: '"+lifecycleResponse.State.Id+"'")
 		tflog.Debug(ctx, "Lifecycle Operation HTTP Status: '"+response.HttpResponse.Status+"'")
+		if response.HttpResponse.StatusCode == http.StatusConflict {
+			continue
+		}
+		tflog.Debug(ctx, "Lifecycle Operation State: '"+lifecycleResponse.State.Id+"'")
 
 		if lifecycleResponse.State.Id == "Succeeded" || lifecycleResponse.State.Id == "Failed" {
 			return &lifecycleResponse, nil

internal/services/application/api_application.go

@@ -123,11 +123,16 @@ func (client *client) InstallApplicationInEnvironment(ctx context.Context, envir
 
 		for {
 			lifecycleResponse := environmentApplicationLifecycleDto{}
-			_, err = client.Api.Execute(ctx, nil, "GET", operationLocationHeader, nil, nil, []int{http.StatusOK}, &lifecycleResponse)
+			response, err := client.Api.Execute(ctx, nil, "GET", operationLocationHeader, nil, nil, []int{http.StatusOK, http.StatusConflict}, &lifecycleResponse)
 			if err != nil {
 				return "", err
 			}
 
+			if response.HttpResponse.StatusCode == http.StatusConflict {
+				tflog.Debug(ctx, "Lifecycle Operation HTTP Status: '"+response.HttpResponse.Status+"'")
+				continue
+			}
+
 			if lifecycleResponse.Status == "Succeeded" {
 				parts := strings.Split(lifecycleResponse.CreatedDateTime, "/")
 				if len(parts) == 0 {

internal/services/environment/api_environment.go

@@ -360,11 +360,16 @@ func (client *Client) AddDataverseToEnvironment(ctx context.Context, environment
 	}
 	for {
 		lifecycleEnv := &EnvironmentDto{}
-		lifecycleResponse, err := client.Api.Execute(ctx, nil, "GET", locationHeader, nil, nil, []int{http.StatusOK, http.StatusAccepted}, &lifecycleEnv)
+		lifecycleResponse, err := client.Api.Execute(ctx, nil, "GET", locationHeader, nil, nil, []int{http.StatusOK, http.StatusAccepted, http.StatusConflict}, &lifecycleEnv)
 		if err != nil {
 			return nil, err
 		}
 
+		tflog.Debug(ctx, fmt.Sprintf("Dataverse Creation Operation HTTP Status: '%s'", lifecycleResponse.HttpResponse.Status))
+		if lifecycleResponse.HttpResponse.StatusCode == http.StatusConflict {
+			continue
+		}
+
 		if lifecycleEnv == nil || lifecycleEnv.Properties == nil {
 			tflog.Debug(ctx, fmt.Sprintf("The environment lifecycle response body did not match expected format. Response status code: %s", lifecycleResponse.HttpResponse.Status))
 			continue
@@ -376,7 +381,6 @@ func (client *Client) AddDataverseToEnvironment(ctx context.Context, environment
 		}
 
 		tflog.Debug(ctx, fmt.Sprintf("Dataverse Creation Operation State: '%s'", lifecycleEnv.Properties.ProvisioningState))
-		tflog.Debug(ctx, fmt.Sprintf("Dataverse Creation Operation HTTP Status: '%s'", lifecycleResponse.HttpResponse.Status))
 
 		if lifecycleEnv.Properties.ProvisioningState == "Succeeded" {
 			return lifecycleEnv, nil

internal/services/tenant_isolation_policy/api_tenant_isolation_policy.go

@@ -165,12 +165,15 @@ func (client *Client) doWaitForLifecycleOperationStatus(ctx context.Context, res
 	}
 
 	for {
-		apiResp, err := client.Api.Execute(ctx, nil, "GET", locationHeader, nil, nil, []int{http.StatusOK, http.StatusAccepted}, nil)
+		apiResp, err := client.Api.Execute(ctx, nil, "GET", locationHeader, nil, nil, []int{http.StatusOK, http.StatusAccepted, http.StatusConflict}, nil)
 		if err != nil {
 			return nil, fmt.Errorf("error polling operation status: %v", err)
 		}
 
 		tflog.Debug(ctx, fmt.Sprintf("Operation poll status: %s", apiResp.HttpResponse.Status))
+		if apiResp.HttpResponse.StatusCode == http.StatusConflict {
+			continue
+		}
 
 		// If we get a 200 OK, the operation is complete
 		if apiResp.HttpResponse.StatusCode == http.StatusOK {