Add connections sweeper and add it to internal package sweepers

internal/config/config.go

@@ -149,6 +149,16 @@ func (c *Config) NewFabricClientForSDK(d *schema.ResourceData) *fabricv4.APIClie
 	return client
 }
 
+// Shim for Fabric tests.
+// Deprecated: when the acceptance package starts to contain API clients for testing/cleanup this will move with them
+func (c *Config) NewFabricClientForTesting() *fabricv4.APIClient {
+	client := c.newFabricClient()
+
+	client.GetConfig().UserAgent = fmt.Sprintf("tf-acceptance-tests %v", client.GetConfig().UserAgent)
+
+	return client
+}
+
 // newFabricClient returns the base fabricv4 client that is then used for either the sdkv2 or framework
 // implementations of the Terraform Provider with exported Methods
 func (c *Config) newFabricClient() *fabricv4.APIClient {

internal/resources/fabric/connection/resource_test.go

@@ -14,17 +14,6 @@ import (
 	"github.com/hashicorp/terraform-plugin-testing/terraform"
 )
 
-func init() {
-	resource.AddTestSweepers("equinix_fabric_connection_PNFV", &resource.Sweeper{
-		Name: "equinix_fabric_connection",
-		F:    testSweepConnections,
-	})
-}
-
-func testSweepConnections(region string) error {
-	return nil
-}
-
 func TestAccFabricCreatePort2SPConnection_PPDS(t *testing.T) {
 	ports := testing_helpers.GetFabricEnvPorts(t)
 	connectionsTestData := testing_helpers.GetFabricEnvConnectionTestData(t)

internal/resources/fabric/connection/sweeper.go

@@ -0,0 +1,76 @@
+package connection
+
+import (
+	"context"
+	"errors"
+	"fmt"
+	"github.com/equinix/equinix-sdk-go/services/fabricv4"
+	equinix_errors "github.com/equinix/terraform-provider-equinix/internal/errors"
+	"github.com/equinix/terraform-provider-equinix/internal/sweep"
+	"log"
+	"strings"
+
+	"github.com/hashicorp/terraform-plugin-testing/helper/resource"
+)
+
+func AddTestSweeper() {
+	resource.AddTestSweepers("equinix_fabric_connection", &resource.Sweeper{
+		Name:         "equinix_fabric_connection",
+		Dependencies: []string{},
+		F:            testSweepConnections,
+	})
+}
+
+func testSweepConnections(region string) error {
+	var errs []error
+	log.Printf("[DEBUG] Sweeping Fabric Connections")
+	ctx := context.Background()
+	meta, err := sweep.GetConfigForFabric()
+	if err != nil {
+		return fmt.Errorf("error getting configuration for sweeping Conections: %s", err)
+	}
+	meta.Load(ctx)
+	fabric := meta.NewFabricClientForTesting()
+
+	name := fabricv4.SEARCHFIELDNAME_NAME
+	equinixStatus := fabricv4.SEARCHFIELDNAME_OPERATION_EQUINIX_STATUS
+	likeOperator := fabricv4.EXPRESSIONOPERATOR_LIKE
+	equalOperator := fabricv4.EXPRESSIONOPERATOR_EQUAL
+	limit := int32(100)
+	connectionsSearchRequest := fabricv4.SearchRequest{
+		Filter: &fabricv4.Expression{
+			And: []fabricv4.Expression{
+				{
+					Property: &name,
+					Operator: &likeOperator,
+					Values:   []string{"PFCR"},
+				},
+				{
+					Property: &equinixStatus,
+					Operator: &equalOperator,
+					Values:   []string{"PROVISIONED"},
+				},
+			},
+		},
+		Pagination: &fabricv4.PaginationRequest{
+			Limit: &limit,
+		},
+	}
+
+	fabricConnections, _, err := fabric.ConnectionsApi.SearchConnections(ctx).SearchRequest(connectionsSearchRequest).Execute()
+	if err != nil {
+		return fmt.Errorf("error getting connections list for sweeping fabric connections: %s", err)
+	}
+
+	for _, connection := range fabricConnections.Data {
+		if strings.HasSuffix(connection.GetName(), "_PFCR") {
+			log.Printf("[DEBUG] Deleting Connection: %s", connection.GetName())
+			_, resp, err := fabric.ConnectionsApi.DeleteConnectionByUuid(ctx, connection.GetUuid()).Execute()
+			if equinix_errors.IgnoreHttpResponseErrors(equinix_errors.HttpForbidden, equinix_errors.HttpNotFound)(resp, err) != nil {
+				errs = append(errs, fmt.Errorf("error deleting fabric connection: %s", err))
+			}
+		}
+	}
+
+	return errors.Join(errs...)
+}

internal/sweep/sweep.go

@@ -20,6 +20,28 @@ func IsSweepableTestResource(namePrefix string) bool {
 	return strings.HasPrefix(namePrefix, testResourcePrefix)
 }
 
+func GetConfigForFabric() (*config.Config, error) {
+	endpoint := env.GetWithDefault(config.EndpointEnvVar, config.DefaultBaseURL)
+	clientId := env.GetWithDefault(config.ClientIDEnvVar, "")
+	clientSecret := env.GetWithDefault(config.ClientSecretEnvVar, "")
+	if clientId == "" || clientSecret == "" {
+		return nil, fmt.Errorf("missing fabric clientId - %s, and clientSecret - %s", config.ClientIDEnvVar, config.ClientSecretEnvVar)
+	}
+
+	clientTimeout := env.GetWithDefault(config.ClientTimeoutEnvVar, strconv.Itoa(config.DefaultTimeout))
+	clientTimeoutInt, err := strconv.Atoi(clientTimeout)
+	if err != nil {
+		return nil, fmt.Errorf("cannot convert value of '%s' env variable to int", config.ClientTimeoutEnvVar)
+	}
+
+	return &config.Config{
+		BaseURL:        endpoint,
+		ClientID:       clientId,
+		ClientSecret:   clientSecret,
+		RequestTimeout: time.Duration(clientTimeoutInt) * time.Second,
+	}, nil
+}
+
 func GetConfigForMetal() (*config.Config, error) {
 	endpoint := env.GetWithDefault(config.EndpointEnvVar, config.DefaultBaseURL)
 	clientTimeout := env.GetWithDefault(config.ClientTimeoutEnvVar, strconv.Itoa(config.DefaultTimeout))

internal/sweep/sweep_test.go

@@ -1,17 +1,19 @@
 package sweep_test
 
 import (
-	"github.com/equinix/terraform-provider-equinix/internal/resources/metal/vlan"
 	"testing"
 
+	fabric_connection "github.com/equinix/terraform-provider-equinix/internal/resources/fabric/connection"
 	"github.com/equinix/terraform-provider-equinix/internal/resources/metal/connection"
 	"github.com/equinix/terraform-provider-equinix/internal/resources/metal/device"
 	"github.com/equinix/terraform-provider-equinix/internal/resources/metal/organization"
 	"github.com/equinix/terraform-provider-equinix/internal/resources/metal/project"
 	"github.com/equinix/terraform-provider-equinix/internal/resources/metal/ssh_key"
 	"github.com/equinix/terraform-provider-equinix/internal/resources/metal/user_api_key"
 	"github.com/equinix/terraform-provider-equinix/internal/resources/metal/virtual_circuit"
+	"github.com/equinix/terraform-provider-equinix/internal/resources/metal/vlan"
 	"github.com/equinix/terraform-provider-equinix/internal/resources/metal/vrf"
+
 	"github.com/hashicorp/terraform-plugin-testing/helper/resource"
 )
 
@@ -25,6 +27,7 @@ func TestMain(m *testing.M) {
 func addTestSweepers() {
 	connection.AddTestSweeper()
 	device.AddTestSweeper()
+	fabric_connection.AddTestSweeper()
 	organization.AddTestSweeper()
 	project.AddTestSweeper()
 	ssh_key.AddTestSweeper()