MGMT-16759: Copy cluster proxy settings to imported local-cluster AgentCluster Install

config/rbac/role.yaml

@@ -294,6 +294,12 @@ rules:
   - get
   - list
   - watch
+- apiGroups:
+  - config.openshift.io
+  resources:
+  - proxies
+  verbs:
+  - get
 - apiGroups:
   - coordination.k8s.io
   resources:

deploy/olm-catalog/manifests/assisted-service-operator.clusterserviceversion.yaml

@@ -673,6 +673,12 @@ spec:
           - get
           - list
           - watch
+        - apiGroups:
+          - config.openshift.io
+          resources:
+          - proxies
+          verbs:
+          - get
         - apiGroups:
           - coordination.k8s.io
           resources:

internal/controller/controllers/agentserviceconfig_controller.go

@@ -201,6 +201,7 @@ type ComponentStatusFn func(context.Context, logrus.FieldLogger, string, appsv1.
 // +kubebuilder:rbac:groups=rbac.authorization.k8s.io,resources=clusterrolebindings,verbs=get;list;watch;create;update;patch;delete
 // +kubebuilder:rbac:groups="",resources=serviceaccounts,verbs=get;list;watch;create;update;patch;delete
 // +kubebuilder:rbac:groups="",resources=namespaces,verbs=get;list;watch;create
+// +kubebuilder:rbac:groups=config.openshift.io,resources=proxies,verbs=get
 // +kubebuilder:rbac:groups="apiregistration.k8s.io",resources=apiservices,verbs=get;list;watch;create;update;patch;delete
 // +kubebuilder:rbac:groups=authorization.k8s.io,resources=subjectaccessreviews,verbs=create
 

pkg/localclusterimport/import_local_cluster.go

@@ -85,7 +85,7 @@ func (i *LocalClusterImport) createLocalClusterPullSecret(sourceSecret *v1.Secre
 	return nil
 }
 
-func (i *LocalClusterImport) createAgentClusterInstall(numberOfControlPlaneNodes int) error {
+func (i *LocalClusterImport) createAgentClusterInstall(numberOfControlPlaneNodes int, proxy *configv1.Proxy) error {
 	//Create an AgentClusterInstall in the local cluster namespace
 	userManagedNetworkingActive := true
 	agentClusterInstall := &hiveext.AgentClusterInstall{
@@ -106,6 +106,14 @@ func (i *LocalClusterImport) createAgentClusterInstall(numberOfControlPlaneNodes
 	}
 	agentClusterInstall.Namespace = i.localClusterNamespace
 	agentClusterInstall.Name = i.localClusterNamespace
+	if proxy != nil {
+		agentClusterInstall.Spec.Proxy = &hiveext.Proxy{
+			HTTPProxy:  proxy.Spec.HTTPProxy,
+			HTTPSProxy: proxy.Spec.HTTPSProxy,
+			NoProxy:    proxy.Spec.NoProxy,
+		}
+	}
+
 	err := i.clusterImportOperations.CreateAgentClusterInstall(agentClusterInstall)
 	if err != nil {
 		i.log.Errorf("could not create AgentClusterInstall due to error %s", err.Error())
@@ -222,6 +230,12 @@ func (i *LocalClusterImport) ImportLocalCluster() error {
 		errorList = multierror.Append(errorList, err)
 	}
 
+	proxy, err := i.clusterImportOperations.GetClusterProxy()
+	if err != nil {
+		i.log.Errorf("could not fetch proxy due to error %s", err.Error())
+		errorList = multierror.Append(errorList, err)
+	}
+
 	numberOfControlPlaneNodes, err := i.clusterImportOperations.GetNumberOfControlPlaneNodes()
 	if err != nil {
 		i.log.Errorf("unable to determine the number of control plane nodes due to error %s", err.Error())
@@ -266,7 +280,7 @@ func (i *LocalClusterImport) ImportLocalCluster() error {
 	}
 
 	if numberOfControlPlaneNodes > 0 {
-		err := i.createAgentClusterInstall(numberOfControlPlaneNodes)
+		err := i.createAgentClusterInstall(numberOfControlPlaneNodes, proxy)
 		if err != nil && !k8serrors.IsAlreadyExists(err) {
 			errorList = multierror.Append(errorList, err)
 		}

pkg/localclusterimport/import_local_cluster_test.go

@@ -36,6 +36,7 @@ var _ = Describe("ImportLocalCluster", func() {
 		agentServiceConfigUID   types.UID
 		releaseImage            string
 		localClusterNamespace   string
+		clusterProxy            *configv1.Proxy
 	)
 
 	BeforeEach(func() {
@@ -193,6 +194,26 @@ var _ = Describe("ImportLocalCluster", func() {
 			Return(dns, nil)
 	}
 
+	var mockGetClusterProxy = func(httpProxy string, httpsProxy string, noProxy string) *gomock.Call {
+		clusterProxy = &configv1.Proxy{
+			Spec: configv1.ProxySpec{
+				HTTPProxy:  httpProxy,
+				HTTPSProxy: httpsProxy,
+				NoProxy:    noProxy,
+			},
+		}
+		return clusterImportOperations.EXPECT().
+			GetClusterProxy().
+			Return(clusterProxy, nil)
+	}
+
+	var mockNilClusterProxy = func() *gomock.Call {
+		clusterProxy = nil
+		return clusterImportOperations.EXPECT().
+			GetClusterProxy().
+			Return(clusterProxy, nil)
+	}
+
 	var mockNumberOfControlPlaneNodesFound = func() *gomock.Call {
 		return clusterImportOperations.EXPECT().
 			GetNumberOfControlPlaneNodes().
@@ -271,6 +292,13 @@ var _ = Describe("ImportLocalCluster", func() {
 		}
 		agentClusterInstall.Namespace = localClusterNamespace
 		agentClusterInstall.Name = localClusterNamespace
+		if clusterProxy != nil {
+			agentClusterInstall.Spec.Proxy = &hiveext.Proxy{
+				HTTPProxy:  clusterProxy.Spec.HTTPProxy,
+				HTTPSProxy: clusterProxy.Spec.HTTPSProxy,
+				NoProxy:    clusterProxy.Spec.NoProxy,
+			}
+		}
 		return agentClusterInstall
 	}
 
@@ -434,6 +462,7 @@ var _ = Describe("ImportLocalCluster", func() {
 		mockNodeKubeConfigsNotFound()
 		mockLocalClusterPullSecretFound()
 		mockClusterDNSFound()
+		mockGetClusterProxy("", "", "")
 		mockNumberOfControlPlaneNodesFound()
 		result := localClusterImport.ImportLocalCluster()
 		multiErrors := result.(*multierror.Error)
@@ -448,6 +477,7 @@ var _ = Describe("ImportLocalCluster", func() {
 		mockNodeKubeConfigsFound()
 		mockLocalClusterPullSecretNotFound()
 		mockClusterDNSFound()
+		mockGetClusterProxy("", "", "")
 		mockNumberOfControlPlaneNodesFound()
 		result := localClusterImport.ImportLocalCluster()
 		multiErrors := result.(*multierror.Error)
@@ -462,6 +492,7 @@ var _ = Describe("ImportLocalCluster", func() {
 		mockNodeKubeConfigsFound()
 		mockLocalClusterPullSecretFound()
 		mockClusterDNSNotFound()
+		mockGetClusterProxy("", "", "")
 		mockNumberOfControlPlaneNodesFound()
 		result := localClusterImport.ImportLocalCluster()
 		multiErrors := result.(*multierror.Error)
@@ -476,6 +507,7 @@ var _ = Describe("ImportLocalCluster", func() {
 		mockNodeKubeConfigsFound()
 		mockLocalClusterPullSecretFound()
 		mockClusterDNSFound()
+		mockGetClusterProxy("", "", "")
 		mockNumberOfControlPlaneNodesFound()
 		mockFailedToCreateClusterImageSet()
 		mockCreateLocalClusterAdminKubeConfig()
@@ -496,6 +528,7 @@ var _ = Describe("ImportLocalCluster", func() {
 		mockNodeKubeConfigsFound()
 		mockLocalClusterPullSecretFound()
 		mockClusterDNSFound()
+		mockGetClusterProxy("", "", "")
 		mockNumberOfControlPlaneNodesFound()
 		mockCreateClusterImageSet()
 		mockFailedToCreateLocalClusterAdminKubeConfig()
@@ -516,6 +549,7 @@ var _ = Describe("ImportLocalCluster", func() {
 		mockNodeKubeConfigsFound()
 		mockLocalClusterPullSecretFound()
 		mockClusterDNSFound()
+		mockGetClusterProxy("", "", "")
 		mockNumberOfControlPlaneNodesFound()
 		mockCreateClusterImageSet()
 		mockCreateLocalClusterAdminKubeConfig()
@@ -536,6 +570,7 @@ var _ = Describe("ImportLocalCluster", func() {
 		mockNodeKubeConfigsFound()
 		mockLocalClusterPullSecretFound()
 		mockClusterDNSFound()
+		mockGetClusterProxy("", "", "")
 		mockNumberOfControlPlaneNodesFound()
 		mockCreateClusterImageSet()
 		mockCreateLocalClusterAdminKubeConfig()
@@ -556,6 +591,7 @@ var _ = Describe("ImportLocalCluster", func() {
 		mockNodeKubeConfigsFound()
 		mockLocalClusterPullSecretFound()
 		mockClusterDNSFound()
+		mockGetClusterProxy("", "", "")
 		mockNumberOfControlPlaneNodesFound()
 		mockCreateClusterImageSet()
 		mockCreateLocalClusterAdminKubeConfig()
@@ -570,12 +606,49 @@ var _ = Describe("ImportLocalCluster", func() {
 		Expect(apiStatus.Status().Message).To(Equal("Invalid parameters"))
 	})
 
+	It("should copy cluster proxy entries to AgentClusterInstall", func() {
+		mockClusterVersionFound()
+		mockCreateNamespace()
+		mockNodeKubeConfigsFound()
+		mockLocalClusterPullSecretFound()
+		mockClusterDNSFound()
+		mockGetClusterProxy("http://http_proxy.net", "https://https_proxy.net", "localhost")
+		mockNumberOfControlPlaneNodesFound()
+		mockCreateClusterImageSet()
+		mockCreateLocalClusterAdminKubeConfig()
+		mockCreateLocalClusterPullSecret()
+		mockCreateAgentClusterInstall()
+		mockGetAgentServiceConfig()
+		mockCreateLocalClusterDeployment()
+		result := localClusterImport.ImportLocalCluster()
+		Expect(result).To(BeNil())
+	})
+
+	It("should skip proxy creation gracefully if Cluster Proxy is nil", func() {
+		mockClusterVersionFound()
+		mockCreateNamespace()
+		mockNodeKubeConfigsFound()
+		mockLocalClusterPullSecretFound()
+		mockClusterDNSFound()
+		mockNilClusterProxy()
+		mockNumberOfControlPlaneNodesFound()
+		mockCreateClusterImageSet()
+		mockCreateLocalClusterAdminKubeConfig()
+		mockCreateLocalClusterPullSecret()
+		mockCreateAgentClusterInstall()
+		mockGetAgentServiceConfig()
+		mockCreateLocalClusterDeployment()
+		result := localClusterImport.ImportLocalCluster()
+		Expect(result).To(BeNil())
+	})
+
 	It("should have created all entities required to import local cluster", func() {
 		mockClusterVersionFound()
 		mockCreateNamespace()
 		mockNodeKubeConfigsFound()
 		mockLocalClusterPullSecretFound()
 		mockClusterDNSFound()
+		mockGetClusterProxy("", "", "")
 		mockNumberOfControlPlaneNodesFound()
 		mockCreateClusterImageSet()
 		mockCreateLocalClusterAdminKubeConfig()
@@ -592,6 +665,7 @@ var _ = Describe("ImportLocalCluster", func() {
 		mockNodeKubeConfigsFound()
 		mockLocalClusterPullSecretFound()
 		mockClusterDNSFound()
+		mockGetClusterProxy("", "", "")
 		mockNumberOfControlPlaneNodesFound()
 		mockAlreadyExistsOnCreateNamespace()
 		mockAlreadyExistsOnCreateClusterImageSet()

pkg/localclusterimport/local_cluster_import_operations.go

@@ -24,6 +24,7 @@ type ClusterImportOperations interface {
 	GetNodes() (*v1.NodeList, error)
 	GetNumberOfControlPlaneNodes() (int, error)
 	GetClusterDNS() (*configv1.DNS, error)
+	GetClusterProxy() (*configv1.Proxy, error)
 	GetAgentServiceConfig() (*aiv1beta1.AgentServiceConfig, error)
 	CreateAgentClusterInstall(agentClusterInstall *hiveext.AgentClusterInstall) error
 	CreateNamespace(name string) error
@@ -203,3 +204,16 @@ func (o *LocalClusterImportOperations) GetClusterDNS() (*configv1.DNS, error) {
 	}
 	return dns, nil
 }
+
+func (o *LocalClusterImportOperations) GetClusterProxy() (*configv1.Proxy, error) {
+	proxy := &configv1.Proxy{}
+	namespacedName := types.NamespacedName{
+		Namespace: "",
+		Name:      "cluster",
+	}
+	err := o.apiReader.Get(o.context, namespacedName, proxy)
+	if err != nil {
+		return nil, err
+	}
+	return proxy, nil
+}