Skip to content

Commit f7db79d

Browse files
committed
r/aws_transfer_certificate: Add sweeper.
1 parent dd22fbb commit f7db79d

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
@@ -16,13 +16,38 @@ import (
1616
)
1717

1818
func RegisterSweepers() {
19+
awsv2.Register("aws_transfer_certificate", sweepCertificates)
1920
awsv2.Register("aws_transfer_connector", sweepConnectors)
2021
awsv2.Register("aws_transfer_profile", sweepProfiles)
2122
awsv2.Register("aws_transfer_server", sweepServers)
2223
awsv2.Register("aws_transfer_web_app", sweepWebApps)
2324
awsv2.Register("aws_transfer_workflow", sweepWorkflows, "aws_transfer_server")
2425
}
2526

27+
func sweepCertificates(ctx context.Context, client *conns.AWSClient) ([]sweep.Sweepable, error) {
28+
conn := client.TransferClient(ctx)
29+
var input transfer.ListCertificatesInput
30+
sweepResources := make([]sweep.Sweepable, 0)
31+
32+
pages := transfer.NewListCertificatesPaginator(conn, &input)
33+
for pages.HasMorePages() {
34+
page, err := pages.NextPage(ctx)
35+
if err != nil {
36+
return nil, err
37+
}
38+
39+
for _, v := range page.Certificates {
40+
r := resourceCertificate()
41+
d := r.Data(nil)
42+
d.SetId(aws.ToString(v.CertificateId))
43+
44+
sweepResources = append(sweepResources, sweep.NewSweepResource(r, d, client))
45+
}
46+
}
47+
48+
return sweepResources, nil
49+
}
50+
2651
func sweepConnectors(ctx context.Context, client *conns.AWSClient) ([]sweep.Sweepable, error) {
2752
conn := client.TransferClient(ctx)
2853
var input transfer.ListConnectorsInput

0 commit comments

Comments
 (0)