Added eks configs (#65)

* Added eks configs

* Added eks configs

* Added eks configs

* Added eks configs

* Added helm package

* Added route53 cleanup method

* Added route53 cleanup method

* Added route53 cleanup method

* Added route53 cleanup method

Author: goruha

pkg/aws/eks.go

@@ -99,7 +99,7 @@ func NewEksClientE(t testing.TestingT, region string) (*eks.Client, error) {
 }
 
 
-func NewK8SClientset(cluster *types.Cluster) (*kubernetes.Clientset, error) {
+func NewK8SClientConfig(cluster *types.Cluster) (*rest.Config, error) {
 	gen, err := token.NewGenerator(true, false)
 	if err != nil {
 		return nil, err
@@ -115,15 +115,24 @@ func NewK8SClientset(cluster *types.Cluster) (*kubernetes.Clientset, error) {
 	if err != nil {
 		return nil, err
 	}
-	clientset, err := kubernetes.NewForConfig(
-		&rest.Config{
-			Host:        *cluster.Endpoint,
-			BearerToken: tok.Token,
-			TLSClientConfig: rest.TLSClientConfig{
-				CAData: ca,
-			},
+
+	return &rest.Config{
+		Host:        *cluster.Endpoint,
+		BearerToken: tok.Token,
+		TLSClientConfig: rest.TLSClientConfig{
+			CAData: ca,
 		},
-	)
+	}, nil
+}
+
+
+func NewK8SClientset(cluster *types.Cluster) (*kubernetes.Clientset, error) {
+	config, err := NewK8SClientConfig(cluster)
+	if err != nil {
+		return nil, err
+	}
+
+	clientset, err := kubernetes.NewForConfig(config)
 	if err != nil {
 		return nil, err
 	}

pkg/aws/route53.go

@@ -7,10 +7,13 @@ import (
 
 	"github.com/aws/aws-sdk-go-v2/service/route53"
 	"github.com/aws/aws-sdk-go-v2/service/route53/types"
-	"github.com/gruntwork-io/terratest/modules/aws"
+	awsTerratest "github.com/gruntwork-io/terratest/modules/aws"
+
+	"github.com/aws/aws-sdk-go-v2/aws"
 )
 
 
+
 func GetDNSZoneByNameE(t *testing.T, ctx context.Context, hostName string, awsRegion string) (*types.HostedZone, error) {
 	if hostName == "" {
 		return nil, fmt.Errorf("hostName cannot be empty")
@@ -19,7 +22,7 @@ func GetDNSZoneByNameE(t *testing.T, ctx context.Context, hostName string, awsRe
 		return nil, fmt.Errorf("awsRegion cannot be empty")
 	}
 
-	client, err := aws.NewRoute53ClientE(t, awsRegion)
+	client, err := awsTerratest.NewRoute53ClientE(t, awsRegion)
 	if err != nil {
 		return nil, err
 	}
@@ -38,3 +41,55 @@ func GetDNSZoneByNameE(t *testing.T, ctx context.Context, hostName string, awsRe
 	}
 	return nil, fmt.Errorf("no exact match found for hosted zone %s", hostName)
 }
+
+func CleanDNSZoneID(t *testing.T, ctx context.Context, zoneID string, awsRegion string) error {
+	route53Client, err := awsTerratest.NewRoute53ClientE(t, awsRegion)
+	if err != nil {
+		return err
+	}
+
+	o, err := route53Client.ListResourceRecordSets(ctx, &route53.ListResourceRecordSetsInput{
+		HostedZoneId:    &zoneID,
+		MaxItems:        aws.Int32(100),
+	})
+	if err != nil {
+		return err
+	}
+
+	var changes []types.Change
+
+	for _, record := range o.ResourceRecordSets {
+
+		if record.Type == types.RRTypeNs || record.Type == types.RRTypeSoa {
+			continue
+		}
+		// Build a deletion change for each record
+		changes = append(changes, types.Change{
+			Action:            types.ChangeActionDelete,
+			ResourceRecordSet: &record,
+		})
+	}
+
+	if len(changes) == 0 {
+		fmt.Println("No deletable records found.")
+		return nil
+	}
+
+	// Prepare the change batch
+	changeBatch := &types.ChangeBatch{
+		Changes: changes,
+	}
+
+	// Call ChangeResourceRecordSets to delete the records
+	changeInput := &route53.ChangeResourceRecordSetsInput{
+		HostedZoneId: aws.String(zoneID),
+		ChangeBatch:  changeBatch,
+	}
+
+	_, err = route53Client.ChangeResourceRecordSets(ctx, changeInput)
+	if err != nil {
+		return err
+	}
+
+	return nil
+}

pkg/helm/metadata.go

@@ -0,0 +1,14 @@
+package helm
+
+type Metadata struct {
+	AppVersion        string `json:"app_version"`
+	Chart             string `json:"chart"`
+	FirstDeployed     float64 `json:"first_deployed"`
+	LastDeployed      float64 `json:"last_deployed"`
+	Name              string `json:"name"`
+	Namespace         string `json:"namespace"`
+	Notes             string `json:"notes"`
+	Revision          int    `json:"revision"`
+	Values            string `json:"values"`
+	Version           string `json:"version"`
+}