Skip to content

Commit dd22fbb

Browse files
committed
r/aws_transfer_profile: Add sweeper.
1 parent b674649 commit dd22fbb

File tree

1 file changed

+25
-0
lines changed

1 file changed

+25
-0
lines changed

internal/service/transfer/sweep.go

Lines changed: 25 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -17,6 +17,7 @@ import (
1717

1818
func RegisterSweepers() {
1919
awsv2.Register("aws_transfer_connector", sweepConnectors)
20+
awsv2.Register("aws_transfer_profile", sweepProfiles)
2021
awsv2.Register("aws_transfer_server", sweepServers)
2122
awsv2.Register("aws_transfer_web_app", sweepWebApps)
2223
awsv2.Register("aws_transfer_workflow", sweepWorkflows, "aws_transfer_server")
@@ -46,6 +47,30 @@ func sweepConnectors(ctx context.Context, client *conns.AWSClient) ([]sweep.Swee
4647
return sweepResources, nil
4748
}
4849

50+
func sweepProfiles(ctx context.Context, client *conns.AWSClient) ([]sweep.Sweepable, error) {
51+
conn := client.TransferClient(ctx)
52+
var input transfer.ListProfilesInput
53+
sweepResources := make([]sweep.Sweepable, 0)
54+
55+
pages := transfer.NewListProfilesPaginator(conn, &input)
56+
for pages.HasMorePages() {
57+
page, err := pages.NextPage(ctx)
58+
if err != nil {
59+
return nil, err
60+
}
61+
62+
for _, v := range page.Profiles {
63+
r := resourceProfile()
64+
d := r.Data(nil)
65+
d.SetId(aws.ToString(v.ProfileId))
66+
67+
sweepResources = append(sweepResources, sweep.NewSweepResource(r, d, client))
68+
}
69+
}
70+
71+
return sweepResources, nil
72+
}
73+
4974
func sweepServers(ctx context.Context, client *conns.AWSClient) ([]sweep.Sweepable, error) {
5075
conn := client.TransferClient(ctx)
5176
var input transfer.ListServersInput

0 commit comments

Comments
 (0)