Scorecard finalizer fix

internal/scorecard/plugins/plugin_runner.go

@@ -392,35 +392,35 @@ func duplicateCRCheck(crs []string) error {
 	return nil
 }
 
-func runTests(csv *olmapiv1alpha1.ClusterServiceVersion, pluginType PluginType, config BasicAndOLMPluginConfig,
+func runTests(csv *olmapiv1alpha1.ClusterServiceVersion, pluginType PluginType, cfg BasicAndOLMPluginConfig,
 	cr string, logFile io.Writer) ([]schelpers.TestResult, string, error) {
 	testResults := make([]schelpers.TestResult, 0)
 
 	logReadWriter := &bytes.Buffer{}
 	log.SetOutput(logReadWriter)
 	log.Printf("Running for cr: %s", cr)
 
-	if !config.OLMDeployed {
-		if err := createFromYAMLFile(config.Namespace, config.GlobalManifest, config.ProxyImage,
-			config.ProxyPullPolicy); err != nil {
+	if !cfg.OLMDeployed {
+		if err := createFromYAMLFile(cfg.Namespace, cfg.GlobalManifest, cfg.ProxyImage,
+			cfg.ProxyPullPolicy, cfg.InitTimeout); err != nil {
 			return testResults, "", fmt.Errorf("failed to create global resources: %v", err)
 		}
-		if err := createFromYAMLFile(config.Namespace, config.NamespacedManifest, config.ProxyImage,
-			config.ProxyPullPolicy); err != nil {
+		if err := createFromYAMLFile(cfg.Namespace, cfg.NamespacedManifest, cfg.ProxyImage,
+			cfg.ProxyPullPolicy, cfg.InitTimeout); err != nil {
 			return testResults, "", fmt.Errorf("failed to create namespaced resources: %v", err)
 		}
 	}
 
-	if err := createFromYAMLFile(config.Namespace, cr, config.ProxyImage, config.ProxyPullPolicy); err != nil {
+	if err := createFromYAMLFile(cfg.Namespace, cr, cfg.ProxyImage, cfg.ProxyPullPolicy, cfg.InitTimeout); err != nil {
 		return testResults, "", fmt.Errorf("failed to create cr resource: %v", err)
 	}
 
-	obj, err := yamlToUnstructured(config.Namespace, cr)
+	obj, err := yamlToUnstructured(cfg.Namespace, cr)
 	if err != nil {
 		return testResults, "", fmt.Errorf("failed to decode custom resource manifest into object: %s", err)
 	}
 
-	if err := waitUntilCRStatusExists(time.Second*time.Duration(config.InitTimeout), obj); err != nil {
+	if err := waitUntilCRStatusExists(time.Second*time.Duration(cfg.InitTimeout), obj); err != nil {
 		return testResults, "", fmt.Errorf("failed waiting to check if CR status exists: %v", err)
 	}
 
@@ -443,9 +443,9 @@ func runTests(csv *olmapiv1alpha1.ClusterServiceVersion, pluginType PluginType,
 			Client:   runtimeClient,
 			CR:       obj,
 			CSV:      csv,
-			CRDsDir:  config.CRDsDir,
+			CRDsDir:  cfg.CRDsDir,
 			ProxyPod: proxyPodGlobal,
-			Bundle:   config.Bundle,
+			Bundle:   cfg.Bundle,
 		}
 
 		tests = append(tests, NewBundleValidationTest(conf))
@@ -456,7 +456,7 @@ func runTests(csv *olmapiv1alpha1.ClusterServiceVersion, pluginType PluginType,
 
 	}
 
-	tests = applySelector(tests, config.Selector)
+	tests = applySelector(tests, cfg.Selector)
 
 	for _, test := range tests {
 		testResults = append(testResults, *test.Run(context.TODO()))

internal/scorecard/plugins/resource_handler.go

@@ -87,7 +87,7 @@ func yamlToUnstructured(namespace, yamlPath string) (*unstructured.Unstructured,
 
 // createFromYAMLFile will take a path to a YAML file and create the resource. If it finds a
 // deployment, it will add the scorecard proxy as a container in the deployments podspec.
-func createFromYAMLFile(namespace, yamlPath, proxyImage string, pullPolicy v1.PullPolicy) error {
+func createFromYAMLFile(namespace, yamlPath, proxyImage string, pullPolicy v1.PullPolicy, initTimeout int) error {
 	yamlSpecs, err := ioutil.ReadFile(yamlPath)
 	if err != nil {
 		return fmt.Errorf("failed to read file %s: %v", yamlPath, err)
@@ -148,7 +148,7 @@ func createFromYAMLFile(namespace, yamlPath, proxyImage string, pullPolicy v1.Pu
 				return err
 			}
 		}
-		addResourceCleanup(obj, types.NamespacedName{Namespace: obj.GetNamespace(), Name: obj.GetName()})
+		addResourceCleanup(obj, types.NamespacedName{Namespace: obj.GetNamespace(), Name: obj.GetName()}, initTimeout)
 		if obj.GetKind() == "Deployment" {
 			proxyPodGlobal, err = getPodFromDeployment(deploymentName, namespace)
 			if err != nil {
@@ -248,7 +248,7 @@ func createKubeconfigSecret(namespace string) error {
 		return err
 	}
 	addResourceCleanup(kubeconfigSecret, types.NamespacedName{Namespace: kubeconfigSecret.GetNamespace(),
-		Name: kubeconfigSecret.GetName()})
+		Name: kubeconfigSecret.GetName()}, 60)
 	return nil
 }
 
@@ -345,15 +345,15 @@ func cleanupScorecard() error {
 }
 
 // addResourceCleanup adds a cleanup function for the specified runtime object
-func addResourceCleanup(obj runtime.Object, key types.NamespacedName) {
+func addResourceCleanup(obj runtime.Object, key types.NamespacedName, initTimeout int) {
 	cleanupFns = append(cleanupFns, func() error {
 		// make a copy of the object because the client changes it
 		objCopy := obj.DeepCopyObject()
 		err := runtimeClient.Delete(context.TODO(), obj)
 		if err != nil && !apierrors.IsNotFound(err) {
 			return err
 		}
-		err = wait.PollImmediate(time.Second*1, time.Second*10, func() (bool, error) {
+		err = wait.PollImmediate(time.Second*1, time.Second*time.Duration(initTimeout), func() (bool, error) {
 			err = runtimeClient.Get(context.TODO(), key, objCopy)
 			if err != nil {
 				if apierrors.IsNotFound(err) {