Merge pull request #867 from andykrohg/main

hunterkepley · web-flow · commit 1b6dda405d30 · 2025-01-21T10:45:49.000-05:00
OCM-13503 | feat: ROSA GovCloud Support
diff --git a/docs/data-sources/policies.md b/docs/data-sources/policies.md
@@ -41,6 +41,7 @@ Read-Only:
 
 Read-Only:
 
+- `openshift_aws_vpce_operator_avo_aws_creds_policy` (String)
 - `openshift_cloud_credential_operator_cloud_credential_operator_iam_ro_creds_policy` (String)
 - `openshift_cloud_network_config_controller_cloud_credentials_policy` (String)
 - `openshift_cluster_csi_drivers_ebs_cloud_credentials_policy` (String)
diff --git a/provider/autoscaler/classic/resource.go b/provider/autoscaler/classic/resource.go
@@ -198,16 +198,16 @@ func (r *ClusterAutoscalerResource) Configure(ctx context.Context, req resource.
 		return
 	}
 
-	collection, ok := req.ProviderData.(*sdk.Connection)
+	connection, ok := req.ProviderData.(*sdk.Connection)
 	if !ok {
 		resp.Diagnostics.AddError("Unexpected Resource Configure Type",
 			fmt.Sprintf("Expected *sdk.Connaction, got: %T. Please report this issue to the provider developers.", req.ProviderData),
 		)
 		return
 	}
 
-	r.collection = collection.ClustersMgmt().V1().Clusters()
-	r.clusterWait = common.NewClusterWait(r.collection)
+	r.collection = connection.ClustersMgmt().V1().Clusters()
+	r.clusterWait = common.NewClusterWait(r.collection, connection)
 }
 
 func (r *ClusterAutoscalerResource) Create(ctx context.Context, request resource.CreateRequest, response *resource.CreateResponse) {
diff --git a/provider/autoscaler/hcp/resource.go b/provider/autoscaler/hcp/resource.go
@@ -101,16 +101,16 @@ func (r *ClusterAutoscalerResource) Configure(ctx context.Context, req resource.
 		return
 	}
 
-	collection, ok := req.ProviderData.(*sdk.Connection)
+	connection, ok := req.ProviderData.(*sdk.Connection)
 	if !ok {
 		resp.Diagnostics.AddError("Unexpected Resource Configure Type",
 			fmt.Sprintf("Expected *sdk.Connaction, got: %T. Please report this issue to the provider developers.", req.ProviderData),
 		)
 		return
 	}
 
-	r.collection = collection.ClustersMgmt().V1().Clusters()
-	r.clusterWait = common.NewClusterWait(r.collection)
+	r.collection = connection.ClustersMgmt().V1().Clusters()
+	r.clusterWait = common.NewClusterWait(r.collection, connection)
 }
 
 func (r *ClusterAutoscalerResource) Create(ctx context.Context, request resource.CreateRequest, response *resource.CreateResponse) {
diff --git a/provider/clusterrosa/classic/cluster_rosa_classic_datasource.go b/provider/clusterrosa/classic/cluster_rosa_classic_datasource.go
@@ -345,7 +345,7 @@ func (r *ClusterRosaClassicDatasource) Configure(ctx context.Context, req dataso
 
 	r.clusterCollection = connection.ClustersMgmt().V1().Clusters()
 	r.versionCollection = connection.ClustersMgmt().V1().Versions()
-	r.clusterWait = common.NewClusterWait(r.clusterCollection)
+	r.clusterWait = common.NewClusterWait(r.clusterCollection, connection)
 }
 
 func (r *ClusterRosaClassicDatasource) Read(ctx context.Context, request datasource.ReadRequest,
diff --git a/provider/clusterrosa/classic/cluster_rosa_classic_resource.go b/provider/clusterrosa/classic/cluster_rosa_classic_resource.go
@@ -482,7 +482,7 @@ func (r *ClusterRosaClassicResource) Configure(ctx context.Context, req resource
 
 	r.ClusterCollection = connection.ClustersMgmt().V1().Clusters()
 	r.VersionCollection = connection.ClustersMgmt().V1().Versions()
-	r.ClusterWait = common.NewClusterWait(r.ClusterCollection)
+	r.ClusterWait = common.NewClusterWait(r.ClusterCollection, connection)
 }
 
 const (
diff --git a/provider/clusterrosa/hcp/datasource.go b/provider/clusterrosa/hcp/datasource.go
@@ -310,7 +310,7 @@ func (r *ClusterRosaHcpDatasource) Configure(ctx context.Context, req datasource
 
 	r.clusterCollection = connection.ClustersMgmt().V1().Clusters()
 	r.versionCollection = connection.ClustersMgmt().V1().Versions()
-	r.clusterWait = common.NewClusterWait(r.clusterCollection)
+	r.clusterWait = common.NewClusterWait(r.clusterCollection, connection)
 }
 
 func (r *ClusterRosaHcpDatasource) Read(ctx context.Context, request datasource.ReadRequest,
diff --git a/provider/clusterrosa/hcp/resource.go b/provider/clusterrosa/hcp/resource.go
@@ -433,7 +433,7 @@ func (r *ClusterRosaHcpResource) Configure(ctx context.Context, req resource.Con
 
 	r.ClusterCollection = connection.ClustersMgmt().V1().Clusters()
 	r.VersionCollection = connection.ClustersMgmt().V1().Versions()
-	r.ClusterWait = common.NewClusterWait(r.ClusterCollection)
+	r.ClusterWait = common.NewClusterWait(r.ClusterCollection, connection)
 }
 
 const (
diff --git a/provider/clusterwaiter/cluster_waiter_resource.go b/provider/clusterwaiter/cluster_waiter_resource.go
@@ -79,7 +79,7 @@ func (r *ClusterWaiterResource) Configure(ctx context.Context, req resource.Conf
 	}
 
 	r.collection = connection.ClustersMgmt().V1().Clusters()
-	r.clusterWait = common.NewClusterWait(r.collection)
+	r.clusterWait = common.NewClusterWait(r.collection, connection)
 }
 
 func (r *ClusterWaiterResource) Create(ctx context.Context, req resource.CreateRequest, resp *resource.CreateResponse) {
diff --git a/provider/common/cluster_waiter.go b/provider/common/cluster_waiter.go
@@ -7,6 +7,7 @@ import (
 	"time"
 
 	"github.com/hashicorp/terraform-plugin-log/tflog"
+	sdk "github.com/openshift-online/ocm-sdk-go"
 	cmv1 "github.com/openshift-online/ocm-sdk-go/clustersmgmt/v1"
 )
 
@@ -20,10 +21,14 @@ type ClusterWait interface {
 
 type DefaultClusterWait struct {
 	collection *cmv1.ClustersClient
+	connection *sdk.Connection
 }
 
-func NewClusterWait(collection *cmv1.ClustersClient) ClusterWait {
-	return &DefaultClusterWait{collection: collection}
+func NewClusterWait(collection *cmv1.ClustersClient, connection *sdk.Connection) ClusterWait {
+	return &DefaultClusterWait{
+		collection: collection,
+		connection: connection,
+	}
 }
 
 func (dw *DefaultClusterWait) WaitForStdComputeNodesToBeReady(ctx context.Context, clusterId string, waitTimeoutMin int64) (*cmv1.Cluster, error) {
@@ -49,6 +54,8 @@ func (dw *DefaultClusterWait) WaitForStdComputeNodesToBeReady(ctx context.Contex
 	backoffSleep := 30 * time.Second
 	var cluster *cmv1.Cluster
 	for cluster == nil {
+		tflog.Debug(ctx, fmt.Sprintf("Updating tokens for cluster %s", clusterId))
+		dw.connection.Tokens()
 		cluster, err = pollClusterCurrentCompute(clusterId, ctx, waitTimeoutMin, dw.collection)
 		if err != nil {
 			backoffAttempts--
@@ -98,6 +105,8 @@ func (dw *DefaultClusterWait) WaitForClusterToBeReady(ctx context.Context, clust
 	backoffSleep := 30 * time.Second
 	var cluster *cmv1.Cluster
 	for cluster == nil {
+		tflog.Debug(ctx, fmt.Sprintf("Updating tokens for cluster %s", clusterId))
+		dw.connection.Tokens()
 		cluster, err = pollClusterState(clusterId, ctx, waitTimeoutMin, dw.collection)
 		if err != nil {
 			backoffAttempts--
diff --git a/provider/defaultingress/classic/resource.go b/provider/defaultingress/classic/resource.go
@@ -141,16 +141,16 @@ func (r *DefaultIngressResource) Configure(ctx context.Context, req resource.Con
 		return
 	}
 
-	collection, ok := req.ProviderData.(*sdk.Connection)
+	connection, ok := req.ProviderData.(*sdk.Connection)
 	if !ok {
 		resp.Diagnostics.AddError("Unexpected Resource Configure Type",
-			fmt.Sprintf("Expected *sdk.Connaction, got: %T. Please report this issue to the provider developers.", req.ProviderData),
+			fmt.Sprintf("Expected *sdk.Connection, got: %T. Please report this issue to the provider developers.", req.ProviderData),
 		)
 		return
 	}
 
-	r.collection = collection.ClustersMgmt().V1().Clusters()
-	r.clusterWait = common.NewClusterWait(r.collection)
+	r.collection = connection.ClustersMgmt().V1().Clusters()
+	r.clusterWait = common.NewClusterWait(r.collection, connection)
 }
 
 func (r *DefaultIngressResource) Create(ctx context.Context, req resource.CreateRequest, resp *resource.CreateResponse) {
diff --git a/provider/defaultingress/hcp/resource.go b/provider/defaultingress/hcp/resource.go
@@ -78,16 +78,16 @@ func (r *DefaultIngressResource) Configure(ctx context.Context, req resource.Con
 		return
 	}
 
-	collection, ok := req.ProviderData.(*sdk.Connection)
+	connection, ok := req.ProviderData.(*sdk.Connection)
 	if !ok {
 		resp.Diagnostics.AddError("Unexpected Resource Configure Type",
 			fmt.Sprintf("Expected *sdk.Connaction, got: %T. Please report this issue to the provider developers.", req.ProviderData),
 		)
 		return
 	}
 
-	r.collection = collection.ClustersMgmt().V1().Clusters()
-	r.clusterWait = common.NewClusterWait(r.collection)
+	r.collection = connection.ClustersMgmt().V1().Clusters()
+	r.clusterWait = common.NewClusterWait(r.collection, connection)
 }
 
 func (r *DefaultIngressResource) Create(ctx context.Context, req resource.CreateRequest, resp *resource.CreateResponse) {
diff --git a/provider/groupmembership/group_membership_resource.go b/provider/groupmembership/group_membership_resource.go
@@ -95,7 +95,7 @@ func (g *GroupMembershipResource) Configure(ctx context.Context, req resource.Co
 	}
 
 	g.collection = connection.ClustersMgmt().V1().Clusters()
-	g.clusterWait = common.NewClusterWait(g.collection)
+	g.clusterWait = common.NewClusterWait(g.collection, connection)
 }
 
 func (g *GroupMembershipResource) Create(ctx context.Context, req resource.CreateRequest, resp *resource.CreateResponse) {
diff --git a/provider/info/consts.go b/provider/info/consts.go
@@ -18,13 +18,19 @@ package info
 type ocmEnv string
 
 const (
-	ocmEnvProd  ocmEnv = "production"
-	ocmEnvStage ocmEnv = "stage"
-	ocmEnvInt   ocmEnv = "integration"
+	ocmEnvProd         ocmEnv = "production"
+	ocmEnvStage        ocmEnv = "stage"
+	ocmEnvInt          ocmEnv = "integration"
+	ocmEnvFedRAMPProd  ocmEnv = "fedramp-production"
+	ocmEnvFedRAMPStage ocmEnv = "fedramp-stage"
+	ocmEnvFedRAMPInt   ocmEnv = "fedramp-int"
 )
 
 var ocmAWSAccounts = map[ocmEnv]string{
-	ocmEnvProd:  "710019948333",
-	ocmEnvStage: "644306948063",
-	ocmEnvInt:   "896164604406",
+	ocmEnvProd:         "710019948333",
+	ocmEnvStage:        "644306948063",
+	ocmEnvInt:          "896164604406",
+	ocmEnvFedRAMPProd:  "448648337690",
+	ocmEnvFedRAMPStage: "448870092490",
+	ocmEnvFedRAMPInt:   "449053620653",
 }
diff --git a/provider/info/info_data_source.go b/provider/info/info_data_source.go
@@ -140,12 +140,21 @@ func (d *OCMInfoDataSource) Read(ctx context.Context, req datasource.ReadRequest
 }
 
 func extractOCMAWSAccount(url string) string {
-	env := ocmEnvProd
-	if strings.Contains(url, "stage") {
-		env = ocmEnvStage
-	} else if strings.Contains(url, "integration") {
-		env = ocmEnvInt
+	if strings.Contains(url, "openshiftusgov.com") {
+		if strings.Contains(url, "stage") {
+			return ocmAWSAccounts[ocmEnvFedRAMPStage]
+		} else if strings.Contains(url, "int") {
+			return ocmAWSAccounts[ocmEnvFedRAMPInt]
+		} else {
+			return ocmAWSAccounts[ocmEnvFedRAMPProd]
+		}
+	} else {
+		if strings.Contains(url, "stage") {
+			return ocmAWSAccounts[ocmEnvStage]
+		} else if strings.Contains(url, "integration") {
+			return ocmAWSAccounts[ocmEnvInt]
+		} else {
+			return ocmAWSAccounts[ocmEnvProd]
+		}
 	}
-
-	return ocmAWSAccounts[env]
 }
diff --git a/provider/kubeletconfig/kubeletconfig_resource.go b/provider/kubeletconfig/kubeletconfig_resource.go
@@ -338,7 +338,7 @@ func (k *KubeletConfigResource) Configure(_ context.Context, req resource.Config
 	clusterCollection := connection.ClustersMgmt().V1().Clusters()
 	k.clusterClient = common.NewClusterClient(clusterCollection)
 	k.configsClient = client.NewKubeletConfigsClient(clusterCollection)
-	k.clusterWait = common.NewClusterWait(clusterCollection)
+	k.clusterWait = common.NewClusterWait(clusterCollection, connection)
 }
 
 func isHCP(ctx context.Context, clusterId string, clusterClient common.ClusterClient) (bool, error) {
diff --git a/provider/machinepool/classic/machine_pool_resource.go b/provider/machinepool/classic/machine_pool_resource.go
@@ -254,7 +254,7 @@ func (r *MachinePoolResource) Configure(ctx context.Context, req resource.Config
 	}
 
 	r.clusterCollection = connection.ClustersMgmt().V1().Clusters()
-	r.clusterWait = common.NewClusterWait(r.clusterCollection)
+	r.clusterWait = common.NewClusterWait(r.clusterCollection, connection)
 }
 
 func (r *MachinePoolResource) Create(ctx context.Context, req resource.CreateRequest, resp *resource.CreateResponse) {
diff --git a/provider/machinepool/hcp/machine_pool_resource.go b/provider/machinepool/hcp/machine_pool_resource.go
@@ -245,7 +245,7 @@ func (r *HcpMachinePoolResource) Configure(ctx context.Context, req resource.Con
 
 	r.clusterCollection = connection.ClustersMgmt().V1().Clusters()
 	r.versionCollection = connection.ClustersMgmt().V1().Versions()
-	r.clusterWait = common.NewClusterWait(r.clusterCollection)
+	r.clusterWait = common.NewClusterWait(r.clusterCollection, connection)
 }
 
 func (r *HcpMachinePoolResource) Create(ctx context.Context, req resource.CreateRequest, resp *resource.CreateResponse) {
diff --git a/provider/ocm_policies/classic/ocm_policies_data_source.go b/provider/ocm_policies/classic/ocm_policies_data_source.go
@@ -38,6 +38,7 @@ const (
 	IngressOperator          = "openshift_ingress_operator_cloud_credentials_policy"
 	SharedVpcIngressOperator = "shared_vpc_openshift_ingress_operator_cloud_credentials_policy"
 	MachineAPI               = "openshift_machine_api_aws_cloud_credentials_policy"
+	AvoCredentials           = "openshift_aws_vpce_operator_avo_aws_creds_policy"
 
 	// Policy IDs from type account roles
 	Installer            = "sts_installer_permission_policy"
@@ -90,6 +91,9 @@ func (s *OcmPoliciesDataSource) Schema(ctx context.Context, req datasource.Schem
 					MachineAPI: schema.StringAttribute{
 						Computed: true,
 					},
+					AvoCredentials: schema.StringAttribute{
+						Computed: true,
+					},
 				},
 				Computed: true,
 			},
@@ -166,6 +170,8 @@ func (s *OcmPoliciesDataSource) Read(ctx context.Context, req datasource.ReadReq
 			operatorRolePolicies.SharedVpcIngressOperator = types.StringValue(awsPolicy.Details())
 		case MachineAPI:
 			operatorRolePolicies.MachineAPI = types.StringValue(awsPolicy.Details())
+		case AvoCredentials:
+			operatorRolePolicies.AvoCredentials = types.StringValue(awsPolicy.Details())
 		// account roles
 		case Installer:
 			accountRolePolicies.Installer = types.StringValue(awsPolicy.Details())
diff --git a/provider/ocm_policies/classic/ocm_policies_state.go b/provider/ocm_policies/classic/ocm_policies_state.go
@@ -31,6 +31,7 @@ type OperatorRolePolicies struct {
 	IngressOperator          types.String `tfsdk:"openshift_ingress_operator_cloud_credentials_policy"`
 	SharedVpcIngressOperator types.String `tfsdk:"shared_vpc_openshift_ingress_operator_cloud_credentials_policy"`
 	MachineAPI               types.String `tfsdk:"openshift_machine_api_aws_cloud_credentials_policy"`
+	AvoCredentials           types.String `tfsdk:"openshift_aws_vpce_operator_avo_aws_creds_policy"`
 }
 
 type AccountRolePolicies struct {
diff --git a/provider/tuningconfigs/resource.go b/provider/tuningconfigs/resource.go
@@ -80,16 +80,16 @@ func (r *TuningConfigResource) Configure(ctx context.Context, req resource.Confi
 		return
 	}
 
-	collection, ok := req.ProviderData.(*sdk.Connection)
+	connection, ok := req.ProviderData.(*sdk.Connection)
 	if !ok {
 		resp.Diagnostics.AddError("Unexpected Resource Configure Type",
 			fmt.Sprintf("Expected *sdk.Connaction, got: %T. Please report this issue to the provider developers.", req.ProviderData),
 		)
 		return
 	}
 
-	r.collection = collection.ClustersMgmt().V1().Clusters()
-	r.clusterWait = common.NewClusterWait(r.collection)
+	r.collection = connection.ClustersMgmt().V1().Clusters()
+	r.clusterWait = common.NewClusterWait(r.collection, connection)
 }
 
 func (r *TuningConfigResource) Create(ctx context.Context, req resource.CreateRequest, resp *resource.CreateResponse) {
diff --git a/subsystem/classic/rosa_ocm_policies_data_source_test.go b/subsystem/classic/rosa_ocm_policies_data_source_test.go
@@ -230,6 +230,7 @@ var _ = Describe("OCM policies data source", func() {
 					"openshift_ingress_operator_cloud_credentials_policy":                               "{}",
 					"shared_vpc_openshift_ingress_operator_cloud_credentials_policy":                    "{}",
 					"openshift_machine_api_aws_cloud_credentials_policy":                                "{}",
+					"openshift_aws_vpce_operator_avo_aws_creds_policy":                                  nil,
 				},
 				"account_role_policies": map[string]interface{}{
 					"sts_installer_permission_policy":             "{}",

Original file line number	Diff line number	Diff line change
`@@ -198,16 +198,16 @@ func (r *ClusterAutoscalerResource) Configure(ctx context.Context, req resource.`
`198`	`198`	`return`
`199`	`199`	`}`
`200`	`200`
`201`		`- collection, ok := req.ProviderData.(*sdk.Connection)`
	`201`	`+ connection, ok := req.ProviderData.(*sdk.Connection)`
`202`	`202`	`if !ok {`
`203`	`203`	`resp.Diagnostics.AddError("Unexpected Resource Configure Type",`
`204`	`204`	`fmt.Sprintf("Expected *sdk.Connaction, got: %T. Please report this issue to the provider developers.", req.ProviderData),`
`205`	`205`	`)`
`206`	`206`	`return`
`207`	`207`	`}`
`208`	`208`
`209`		`- r.collection = collection.ClustersMgmt().V1().Clusters()`
`210`		`- r.clusterWait = common.NewClusterWait(r.collection)`
	`209`	`+ r.collection = connection.ClustersMgmt().V1().Clusters()`
	`210`	`+ r.clusterWait = common.NewClusterWait(r.collection, connection)`
`211`	`211`	`}`
`212`	`212`
`213`	`213`	`func (r ClusterAutoscalerResource) Create(ctx context.Context, request resource.CreateRequest, response resource.CreateResponse) {`
Original file line number	Diff line number	Diff line change
`@@ -101,16 +101,16 @@ func (r *ClusterAutoscalerResource) Configure(ctx context.Context, req resource.`
`101`	`101`	`return`
`102`	`102`	`}`
`103`	`103`
`104`		`- collection, ok := req.ProviderData.(*sdk.Connection)`
	`104`	`+ connection, ok := req.ProviderData.(*sdk.Connection)`
`105`	`105`	`if !ok {`
`106`	`106`	`resp.Diagnostics.AddError("Unexpected Resource Configure Type",`
`107`	`107`	`fmt.Sprintf("Expected *sdk.Connaction, got: %T. Please report this issue to the provider developers.", req.ProviderData),`
`108`	`108`	`)`
`109`	`109`	`return`
`110`	`110`	`}`
`111`	`111`
`112`		`- r.collection = collection.ClustersMgmt().V1().Clusters()`
`113`		`- r.clusterWait = common.NewClusterWait(r.collection)`
	`112`	`+ r.collection = connection.ClustersMgmt().V1().Clusters()`
	`113`	`+ r.clusterWait = common.NewClusterWait(r.collection, connection)`
`114`	`114`	`}`
`115`	`115`
`116`	`116`	`func (r ClusterAutoscalerResource) Create(ctx context.Context, request resource.CreateRequest, response resource.CreateResponse) {`
Original file line number	Diff line number	Diff line change
`@@ -345,7 +345,7 @@ func (r *ClusterRosaClassicDatasource) Configure(ctx context.Context, req dataso`
`345`	`345`
`346`	`346`	`r.clusterCollection = connection.ClustersMgmt().V1().Clusters()`
`347`	`347`	`r.versionCollection = connection.ClustersMgmt().V1().Versions()`
`348`		`- r.clusterWait = common.NewClusterWait(r.clusterCollection)`
	`348`	`+ r.clusterWait = common.NewClusterWait(r.clusterCollection, connection)`
`349`	`349`	`}`
`350`	`350`
`351`	`351`	`func (r *ClusterRosaClassicDatasource) Read(ctx context.Context, request datasource.ReadRequest,`
Original file line number	Diff line number	Diff line change
`@@ -482,7 +482,7 @@ func (r *ClusterRosaClassicResource) Configure(ctx context.Context, req resource`
`482`	`482`
`483`	`483`	`r.ClusterCollection = connection.ClustersMgmt().V1().Clusters()`
`484`	`484`	`r.VersionCollection = connection.ClustersMgmt().V1().Versions()`
`485`		`- r.ClusterWait = common.NewClusterWait(r.ClusterCollection)`
	`485`	`+ r.ClusterWait = common.NewClusterWait(r.ClusterCollection, connection)`
`486`	`486`	`}`
`487`	`487`
`488`	`488`	`const (`
Original file line number	Diff line number	Diff line change
`@@ -310,7 +310,7 @@ func (r *ClusterRosaHcpDatasource) Configure(ctx context.Context, req datasource`
`310`	`310`
`311`	`311`	`r.clusterCollection = connection.ClustersMgmt().V1().Clusters()`
`312`	`312`	`r.versionCollection = connection.ClustersMgmt().V1().Versions()`
`313`		`- r.clusterWait = common.NewClusterWait(r.clusterCollection)`
	`313`	`+ r.clusterWait = common.NewClusterWait(r.clusterCollection, connection)`
`314`	`314`	`}`
`315`	`315`
`316`	`316`	`func (r *ClusterRosaHcpDatasource) Read(ctx context.Context, request datasource.ReadRequest,`
Original file line number	Diff line number	Diff line change
`@@ -433,7 +433,7 @@ func (r *ClusterRosaHcpResource) Configure(ctx context.Context, req resource.Con`
`433`	`433`
`434`	`434`	`r.ClusterCollection = connection.ClustersMgmt().V1().Clusters()`
`435`	`435`	`r.VersionCollection = connection.ClustersMgmt().V1().Versions()`
`436`		`- r.ClusterWait = common.NewClusterWait(r.ClusterCollection)`
	`436`	`+ r.ClusterWait = common.NewClusterWait(r.ClusterCollection, connection)`
`437`	`437`	`}`
`438`	`438`
`439`	`439`	`const (`
Original file line number	Diff line number	Diff line change
`@@ -79,7 +79,7 @@ func (r *ClusterWaiterResource) Configure(ctx context.Context, req resource.Conf`
`79`	`79`	`}`
`80`	`80`
`81`	`81`	`r.collection = connection.ClustersMgmt().V1().Clusters()`
`82`		`- r.clusterWait = common.NewClusterWait(r.collection)`
	`82`	`+ r.clusterWait = common.NewClusterWait(r.collection, connection)`
`83`	`83`	`}`
`84`	`84`
`85`	`85`	`func (r ClusterWaiterResource) Create(ctx context.Context, req resource.CreateRequest, resp resource.CreateResponse) {`
Original file line number	Diff line number	Diff line change
`@@ -141,16 +141,16 @@ func (r *DefaultIngressResource) Configure(ctx context.Context, req resource.Con`
`141`	`141`	`return`
`142`	`142`	`}`
`143`	`143`
`144`		`- collection, ok := req.ProviderData.(*sdk.Connection)`
	`144`	`+ connection, ok := req.ProviderData.(*sdk.Connection)`
`145`	`145`	`if !ok {`
`146`	`146`	`resp.Diagnostics.AddError("Unexpected Resource Configure Type",`
`147`		`- fmt.Sprintf("Expected *sdk.Connaction, got: %T. Please report this issue to the provider developers.", req.ProviderData),`
	`147`	`+ fmt.Sprintf("Expected *sdk.Connection, got: %T. Please report this issue to the provider developers.", req.ProviderData),`
`148`	`148`	`)`
`149`	`149`	`return`
`150`	`150`	`}`
`151`	`151`
`152`		`- r.collection = collection.ClustersMgmt().V1().Clusters()`
`153`		`- r.clusterWait = common.NewClusterWait(r.collection)`
	`152`	`+ r.collection = connection.ClustersMgmt().V1().Clusters()`
	`153`	`+ r.clusterWait = common.NewClusterWait(r.collection, connection)`
`154`	`154`	`}`
`155`	`155`
`156`	`156`	`func (r DefaultIngressResource) Create(ctx context.Context, req resource.CreateRequest, resp resource.CreateResponse) {`