test: added sweeper tests (#201)

* added sweeper tests for:
cloudRouters, networks, serviceProfiles

* updated methods name

Author: tutkat

tests/sweepers/cloudRouters.go

@@ -0,0 +1,55 @@
+package sweepers
+
+import (
+	"context"
+	"errors"
+	"fmt"
+	"github.com/equinix/equinix-sdk-go/services/fabricv4"
+	"log"
+	"net/http"
+)
+
+func testSweepCloudRouters() error {
+	var errs []error
+	log.Printf("[DEBUG] Sweeping Fabric Cloud Routers")
+	ctx := context.Background()
+	fabric, err := newFabricClient()
+
+	equinixStatus := "/state"
+	equalOperator := string(fabricv4.EXPRESSIONOPERATOR_EQUAL)
+	limit := int32(100)
+	cloudRouterSearchRequest := fabricv4.CloudRouterSearchRequest{
+		Filter: &fabricv4.CloudRouterFilters{
+			And: []fabricv4.CloudRouterFilter{
+				{
+					CloudRouterSimpleExpression: &fabricv4.CloudRouterSimpleExpression{
+						Property: &equinixStatus,
+						Operator: &equalOperator,
+						Values:   []string{string(fabricv4.EQUINIXSTATUS_PROVISIONED)},
+					},
+				},
+			},
+		},
+		Pagination: &fabricv4.PaginationRequest{
+			Limit: &limit,
+		},
+	}
+
+	fabricCloudRouters, _, err := fabric.CloudRoutersApi.SearchCloudRouters(ctx).CloudRouterSearchRequest(cloudRouterSearchRequest).Execute()
+
+	if err != nil {
+		return fmt.Errorf("error getting fabric cloud router list for sweeping fabric cloud routers: %s", err)
+	}
+
+	for _, cloudRouter := range fabricCloudRouters.Data {
+		if isSweepableFabricTestResource(cloudRouter.GetName()) {
+			log.Printf("[DEBUG] Deleting Cloud Router: %s", cloudRouter.GetName())
+			resp, err := fabric.CloudRoutersApi.DeleteCloudRouterByUuid(ctx, cloudRouter.GetUuid()).Execute()
+			if resp.StatusCode == http.StatusForbidden || resp.StatusCode == http.StatusNotFound {
+				errs = append(errs, fmt.Errorf("error deleting fabric cloud routter: %s", err))
+			}
+		}
+	}
+
+	return errors.Join(errs...)
+}

tests/sweepers/networks.go

@@ -0,0 +1,52 @@
+package sweepers
+
+import (
+	"context"
+	"errors"
+	"fmt"
+	"github.com/equinix/equinix-sdk-go/services/fabricv4"
+	"log"
+	"net/http"
+)
+
+func testSweepNetworks() error {
+	var errs []error
+	log.Printf("[DEBUG] Sweeping Fabric Networks")
+	ctx := context.Background()
+	fabric, err := newFabricClient()
+
+	name := fabricv4.NETWORKSEARCHFIELDNAME_NAME
+	equalOperator := fabricv4.NETWORKFILTEROPERATOR_EQUAL
+	limit := int32(100)
+	offset := int32(0)
+
+	networkSearchRequest := fabricv4.NetworkSearchRequest{
+		Filter: &fabricv4.NetworkFilter{
+			And:      []fabricv4.NetworkFilter{},
+			Property: &name,
+			Operator: &equalOperator,
+			Values:   fabricTestResourceSuffixes,
+		},
+		Pagination: &fabricv4.PaginationRequest{
+			Offset: &offset,
+			Limit:  &limit,
+		},
+	}
+	networks, _, err := fabric.NetworksApi.SearchNetworks(ctx).NetworkSearchRequest(networkSearchRequest).Execute()
+
+	if err != nil {
+		return fmt.Errorf("error getting fabric network list for sweeping fabric networks: %s", err)
+	}
+
+	for _, network := range networks.Data {
+		if network.GetState() != "DELETED" && isSweepableFabricTestResource(network.GetName()) {
+			log.Printf("[DEBUG] Deleting Network: %s", network.GetName())
+			_, resp, err := fabric.NetworksApi.DeleteNetworkByUuid(ctx, network.GetUuid()).Execute()
+			if resp.StatusCode == http.StatusForbidden || resp.StatusCode == http.StatusNotFound {
+				errs = append(errs, fmt.Errorf("error deleting fabric network: %s", err))
+			}
+		}
+	}
+
+	return errors.Join(errs...)
+}

tests/sweepers/serviceProfiles.go

@@ -0,0 +1,58 @@
+package sweepers
+
+import (
+	"context"
+	"errors"
+	"fmt"
+	"github.com/equinix/equinix-sdk-go/services/fabricv4"
+	"log"
+	"net/http"
+)
+
+func testSweepServiceProfiles() error {
+	var errs []error
+	log.Printf("[DEBUG] Sweeping Fabric Service Profiles")
+	ctx := context.Background()
+	fabric, err := newFabricClient()
+
+	limit := int32(100)
+	offset := int32(0)
+	equalOperator := string(fabricv4.EXPRESSIONOPERATOR_EQUAL)
+	state := string(fabricv4.SERVICEPROFILESORTBY_STATE)
+
+	serviceProfileSearchRequest := fabricv4.ServiceProfileSearchRequest{
+		Filter: &fabricv4.ServiceProfileFilter{
+			ServiceProfileAndFilter: &fabricv4.ServiceProfileAndFilter{
+				And: []fabricv4.ServiceProfileSimpleExpression{
+					{
+						Property: &state,
+						Operator: &equalOperator,
+						Values:   []string{string(fabricv4.SERVICEPROFILESTATEENUM_ACTIVE), string(fabricv4.SERVICEPROFILESTATEENUM_PENDING_APPROVAL)},
+					},
+				},
+			},
+		},
+		Pagination: &fabricv4.PaginationRequest{
+			Limit:  &limit,
+			Offset: &offset,
+		},
+	}
+
+	fabricServiceProfiles, _, err := fabric.ServiceProfilesApi.SearchServiceProfiles(ctx).ServiceProfileSearchRequest(serviceProfileSearchRequest).Execute()
+
+	if err != nil {
+		return fmt.Errorf("error getting fabric service profiles list for sweeping fabric service profiles: %s", err)
+	}
+
+	for _, serviceProfile := range fabricServiceProfiles.Data {
+		if isSweepableFabricTestResource(serviceProfile.GetName()) {
+			log.Printf("[DEBUG] Deleting Service Profile: %s", serviceProfile.GetName())
+			_, resp, err := fabric.ServiceProfilesApi.DeleteServiceProfileByUuid(ctx, serviceProfile.GetUuid()).Execute()
+			if resp.StatusCode == http.StatusForbidden || resp.StatusCode == http.StatusNotFound {
+				errs = append(errs, fmt.Errorf("error deleting fabric service profile: %s", err))
+			}
+		}
+	}
+
+	return errors.Join(errs...)
+}

tests/sweepers/sweepers.go

@@ -2,4 +2,7 @@ package sweepers
 
 func RunTestSweepers() {
 	testSweepConnections()
+	testSweepServiceProfiles()
+	testSweepNetworks()
+	testSweepCloudRouters()
 }