Replace informers with sleep timeout

Author: goruha

test/component_test.go

@@ -20,8 +20,8 @@ import (
 	"k8s.io/apimachinery/pkg/apis/meta/v1/unstructured"
 
 	"k8s.io/client-go/dynamic"
-	"k8s.io/client-go/dynamic/dynamicinformer"
-	"k8s.io/client-go/tools/cache"
+	// "k8s.io/client-go/dynamic/dynamicinformer"
+	// "k8s.io/client-go/tools/cache"
 )
 
 type ComponentSuite struct {
@@ -127,67 +127,68 @@ func (s *ComponentSuite) TestBasic() {
 		}
 	}()
 
-
-	// // Wait for the DnsEndpoint to be updated with the LoadBalancer metadata
-	factory := dynamicinformer.NewDynamicSharedInformerFactory(dynamicClient, 0)
-	// Create an informer for the DNSEndpoint resource
-	informer := factory.ForResource(dnsEndpointGVR).Informer()
-
-
-	stopChannel := make(chan struct{})
-	informer.AddEventHandler(cache.ResourceEventHandlerFuncs{
-		UpdateFunc: func(oldObj, newObj interface{}) {
-			_, ok := oldObj.(*unstructured.Unstructured)
-			if !ok {
-				return
-			}
-			newDNS, ok := newObj.(*unstructured.Unstructured)
-			if !ok {
-				return
-			}
-
-			name, found, err := unstructured.NestedString(newDNS.Object, "metadata", "name")
-			if err != nil {
-				fmt.Printf("Error getting name: %v\n", err)
-				return
-			}
-			if !found {
-				fmt.Printf("Name not found\n")
-				return
-			}
-			if name != dnsEndpointName {
-				fmt.Printf("DNS record is not %s\n", dnsEndpointName)
-				return
-			}
-
-			observedGeneration, found, err := unstructured.NestedInt64(newDNS.Object, "status", "observedGeneration")
-			if err != nil {
-				fmt.Printf("Error getting status: %v\n", err)
-				return
-			}
-			if !found {
-				fmt.Printf("Status not found\n")
-				return
-			}
-
-			if observedGeneration > 0 {
-				fmt.Printf("Dns Record %s is ready\n", name)
-				close(stopChannel)
-			} else {
-				fmt.Printf("Dns Record %s is not ready yet\n", name)
-			}
-		},
-	})
-	go informer.Run(stopChannel)
-
-	select {
-		case <-stopChannel:
-			msg := "Dns endpoint created"
-			fmt.Println(msg)
-		case <-time.After(1 * time.Minute):
-			msg := "Dns endpoint creation timed out"
-			assert.Fail(s.T(), msg)
-	}
+	time.Sleep(2 * time.Minute)
+
+	// // // Wait for the DnsEndpoint to be updated with the LoadBalancer metadata
+	// factory := dynamicinformer.NewDynamicSharedInformerFactory(dynamicClient, 0)
+	// // Create an informer for the DNSEndpoint resource
+	// informer := factory.ForResource(dnsEndpointGVR).Informer()
+
+
+	// stopChannel := make(chan struct{})
+	// informer.AddEventHandler(cache.ResourceEventHandlerFuncs{
+	// 	UpdateFunc: func(oldObj, newObj interface{}) {
+	// 		_, ok := oldObj.(*unstructured.Unstructured)
+	// 		if !ok {
+	// 			return
+	// 		}
+	// 		newDNS, ok := newObj.(*unstructured.Unstructured)
+	// 		if !ok {
+	// 			return
+	// 		}
+
+	// 		name, found, err := unstructured.NestedString(newDNS.Object, "metadata", "name")
+	// 		if err != nil {
+	// 			fmt.Printf("Error getting name: %v\n", err)
+	// 			return
+	// 		}
+	// 		if !found {
+	// 			fmt.Printf("Name not found\n")
+	// 			return
+	// 		}
+	// 		if name != dnsEndpointName {
+	// 			fmt.Printf("DNS record is not %s\n", dnsEndpointName)
+	// 			return
+	// 		}
+
+	// 		observedGeneration, found, err := unstructured.NestedInt64(newDNS.Object, "status", "observedGeneration")
+	// 		if err != nil {
+	// 			fmt.Printf("Error getting status: %v\n", err)
+	// 			return
+	// 		}
+	// 		if !found {
+	// 			fmt.Printf("Status not found\n")
+	// 			return
+	// 		}
+
+	// 		if observedGeneration > 0 {
+	// 			fmt.Printf("Dns Record %s is ready\n", name)
+	// 			close(stopChannel)
+	// 		} else {
+	// 			fmt.Printf("Dns Record %s is not ready yet\n", name)
+	// 		}
+	// 	},
+	// })
+	// go informer.Run(stopChannel)
+
+	// select {
+	// 	case <-stopChannel:
+	// 		msg := "Dns endpoint created"
+	// 		fmt.Println(msg)
+	// 	case <-time.After(1 * time.Minute):
+	// 		msg := "Dns endpoint creation timed out"
+	// 		assert.Fail(s.T(), msg)
+	// }
 
 	delegatedNSRecord := awsTerratest.GetRoute53Record(s.T(), defaultDNSZoneId, dnsRecordHostName, "A", awsRegion)
 	assert.Equal(s.T(), fmt.Sprintf("%s.", dnsRecordHostName), *delegatedNSRecord.Name)