bump tools/clean to newest SDK

Author: s-urbaniak

tools/clean/atlas/data_federation.go

@@ -24,7 +24,7 @@ import (
 
 func (c *Cleaner) listFederatedDatabases(ctx context.Context, projectID string) []admin.DataLakeTenant {
 	federatedDBs, _, err := c.client.DataFederationApi.
-		ListFederatedDatabases(ctx, projectID).
+		ListDataFederation(ctx, projectID).
 		Execute()
 	if err != nil {
 		fmt.Println(text.FgRed.Sprintf("\tFailed to list federated databases for project %s: %s", projectID, err))
@@ -43,7 +43,7 @@ func (c *Cleaner) deleteFederatedDatabases(ctx context.Context, projectID string
 			continue
 		}
 
-		_, err := c.client.DataFederationApi.DeleteFederatedDatabase(ctx, projectID, fedDB.GetName()).Execute()
+		_, err := c.client.DataFederationApi.DeleteDataFederation(ctx, projectID, fedDB.GetName()).Execute()
 		if err != nil {
 			fmt.Println(text.FgRed.Sprintf("\t\t\tFailed to request deletion of Federated Database %s: %s", fedDB.GetName(), err))
 		}

tools/clean/atlas/data_federation_private_endpoints.go

@@ -23,7 +23,7 @@ import (
 )
 
 func (c *Cleaner) listFederatedDBPrivateEndpoints(ctx context.Context, projectID string) []admin.PrivateNetworkEndpointIdEntry {
-	federatedDBPEs, _, err := c.client.DataFederationApi.ListDataFederationPrivateEndpoints(ctx, projectID).Execute()
+	federatedDBPEs, _, err := c.client.DataFederationApi.ListPrivateEndpointIds(ctx, projectID).Execute()
 	if err != nil {
 		fmt.Println(text.FgRed.Sprintf("\tFailed to list federated databases for project %s: %s", projectID, err))
 
@@ -35,7 +35,7 @@ func (c *Cleaner) listFederatedDBPrivateEndpoints(ctx context.Context, projectID
 
 func (c *Cleaner) deleteFederatedDBPrivateEndpoints(ctx context.Context, projectID string, dbpes []admin.PrivateNetworkEndpointIdEntry) {
 	for _, fedDBPE := range dbpes {
-		_, err := c.client.DataFederationApi.DeleteDataFederationPrivateEndpoint(ctx, projectID, fedDBPE.GetEndpointId()).Execute()
+		_, err := c.client.DataFederationApi.DeletePrivateEndpointId(ctx, projectID, fedDBPE.GetEndpointId()).Execute()
 		if err != nil {
 			fmt.Println(text.FgRed.Sprintf("\t\t\tFailed to request deletion of Federated DB private endpoint %s: %s", fedDBPE.GetEndpointId(), err))
 		}

tools/clean/atlas/network_peering.go

@@ -34,8 +34,8 @@ func (c *Cleaner) listNetworkPeering(ctx context.Context, projectID string, prov
 }
 
 func (c *Cleaner) listNetworkPeeringForProvider(ctx context.Context, projectID, providerName string) []admin.BaseNetworkPeeringConnectionSettings {
-	queryArgs := admin.ListPeeringConnectionsApiParams{GroupId: projectID, ProviderName: &providerName}
-	peers, _, err := c.client.NetworkPeeringApi.ListPeeringConnectionsWithParams(ctx, &queryArgs).Execute()
+	queryArgs := admin.ListGroupPeersApiParams{GroupId: projectID, ProviderName: &providerName}
+	peers, _, err := c.client.NetworkPeeringApi.ListGroupPeersWithParams(ctx, &queryArgs).Execute()
 	if err != nil {
 		fmt.Println(text.FgRed.Sprintf("\tFailed to list %s networking peering for project %s: %s", providerName, projectID, err))
 		return []admin.BaseNetworkPeeringConnectionSettings{}
@@ -44,7 +44,7 @@ func (c *Cleaner) listNetworkPeeringForProvider(ctx context.Context, projectID,
 }
 
 func (c *Cleaner) getNetworkPeeringContainer(ctx context.Context, projectID, ID string) *admin.CloudProviderContainer {
-	container, _, err := c.client.NetworkPeeringApi.GetPeeringContainer(ctx, projectID, ID).Execute()
+	container, _, err := c.client.NetworkPeeringApi.GetGroupContainer(ctx, projectID, ID).Execute()
 	if err != nil {
 		fmt.Println(text.FgRed.Sprintf("\t\t\tFailed to get network peering container %s: %s", ID, err))
 
@@ -85,7 +85,7 @@ func (c *Cleaner) deleteNetworkPeering(ctx context.Context, projectID string, pe
 			}
 		}
 
-		_, _, err := c.client.NetworkPeeringApi.DeletePeeringConnection(ctx, projectID, peer.GetId()).Execute()
+		_, _, err := c.client.NetworkPeeringApi.DeleteGroupPeer(ctx, projectID, peer.GetId()).Execute()
 		if err != nil {
 			fmt.Println(text.FgRed.Sprintf("\t\t\tFailed to request deletion of network peering %s: %s", peer.GetId(), err))
 

tools/clean/atlas/private_endpoints.go

@@ -24,7 +24,7 @@ import (
 
 func (c *Cleaner) listPrivateEndpoints(ctx context.Context, projectID, cloudProvider string) []admin.EndpointService {
 	endpoints, _, err := c.client.PrivateEndpointServicesApi.
-		ListPrivateEndpointServices(ctx, projectID, cloudProvider).
+		ListPrivateEndpointService(ctx, projectID, cloudProvider).
 		Execute()
 	if err != nil {
 		fmt.Println(text.FgRed.Sprintf("\tFailed to list %s private endpoints for project %s: %s", cloudProvider, projectID, err))

tools/clean/go.mod

@@ -15,7 +15,7 @@ require (
 	github.com/aws/aws-sdk-go-v2/service/kms v1.46.2
 	github.com/aws/smithy-go v1.23.2
 	github.com/jedib0t/go-pretty/v6 v6.7.5
-	go.mongodb.org/atlas-sdk/v20250312006 v20250312006.1.0
+	go.mongodb.org/atlas-sdk/v20250312009 v20250312009.1.0
 	google.golang.org/api v0.256.0
 )
 

tools/clean/go.sum

@@ -119,8 +119,8 @@ github.com/rivo/uniseg v0.4.7 h1:WUdvkW8uEhrYfLC4ZzdpI2ztxP1I582+49Oc5Mq64VQ=
 github.com/rivo/uniseg v0.4.7/go.mod h1:FN3SvrM+Zdj16jyLfmOkMNblXMcoc8DfTHruCPUcx88=
 github.com/stretchr/testify v1.11.1 h1:7s2iGBzp5EwR7/aIZr8ao5+dra3wiQyKjjFuvgVKu7U=
 github.com/stretchr/testify v1.11.1/go.mod h1:wZwfW3scLgRK+23gO65QZefKpKQRnfz6sD981Nm4B6U=
-go.mongodb.org/atlas-sdk/v20250312006 v20250312006.1.0 h1:PcVxslw4G7/I9SbUi5y81i4YZnL1dKRnGpeHVyNSTh4=
-go.mongodb.org/atlas-sdk/v20250312006 v20250312006.1.0/go.mod h1:UZYSaCimjGs3j+wMwgHSKUSIvoJXzmy/xrer0t5TLgo=
+go.mongodb.org/atlas-sdk/v20250312009 v20250312009.1.0 h1:iaFFJcOkT7U5WcuOl8XVAOkPwBlP27coQGJUiDVd3+8=
+go.mongodb.org/atlas-sdk/v20250312009 v20250312009.1.0/go.mod h1:fusey5SPjrcmUiJ+MxvYtEgV7N/lkW3SjacSYYejlAc=
 go.opentelemetry.io/auto/sdk v1.1.0 h1:cH53jehLUN6UFLY71z+NDOiNJqDdPRaXzTel0sJySYA=
 go.opentelemetry.io/auto/sdk v1.1.0/go.mod h1:3wSPjt5PWp2RhlCcmmOial7AvC4DQqZb7a7wCow3W8A=
 go.opentelemetry.io/contrib/instrumentation/google.golang.org/grpc/otelgrpc v0.61.0 h1:q4XOmH/0opmeuJtPsbFNivyl7bCt7yRBbeEm2sC/XtQ=