Issue cycloidio#368: Feature request

Author: kellyj4

CHANGELOG.md

@@ -1,5 +1,9 @@
 ## [Unreleased]
 
+## Added
+- Added new AWS resource `ec2_aws_managed_prefix_lists`
+  ([Issue #368](https://github.com/cycloidio/terracognita/issues/368))
+
 ## Added
 
 - Azurerm now can use the `--tags` filter

aws/cmd/functions.go

@@ -477,6 +477,16 @@ var (
 			// Returned values are commented in the interface doc comment block.
 			`,
 		},
+		Function{
+			FnName:  "GetManagedPrefixLists",
+			Entity:  "ManagedPrefixLists",
+			Prefix:  "Describe",
+			Service: "ec2",
+			Documentation: `
+			// GetManagedPrefixLists returns the ec2 Managed Prefix Lists on the given input
+			// Returned values are commented in the interface doc comment block.
+			`,
+		},
 		Function{
 			FnName:  "GetTransitGateways",
 			Entity:  "TransitGateways",

aws/reader/reader.go

@@ -229,6 +229,10 @@ type Reader interface {
 	// Returned values are commented in the interface doc comment block.
 	GetRouteTables(ctx context.Context, input *ec2.DescribeRouteTablesInput) ([]*ec2.RouteTable, error)
 
+	// GetManagedPrefixLists returns the ec2 Managed Prefix Lists on the given input
+	// Returned values are commented in the interface doc comment block.
+	GetManagedPrefixLists(ctx context.Context, input *ec2.DescribeManagedPrefixListsInput) ([]*ec2.ManagedPrefixList, error)
+
 	// GetTransitGateways returns the ec2 Transit Gateways on the given input
 	// Returned values are commented in the interface doc comment block.
 	GetTransitGateways(ctx context.Context, input *ec2.DescribeTransitGatewaysInput) ([]*ec2.TransitGateway, error)
@@ -1800,6 +1804,37 @@ func (c *connector) GetRouteTables(ctx context.Context, input *ec2.DescribeRoute
 	return opt, nil
 }
 
+func (c *connector) GetManagedPrefixLists(ctx context.Context, input *ec2.DescribeManagedPrefixListsInput) ([]*ec2.ManagedPrefixList, error) {
+	if c.svc.ec2 == nil {
+		c.svc.ec2 = ec2.New(c.svc.session)
+	}
+
+	opt := make([]*ec2.ManagedPrefixList, 0)
+
+	hasNextToken := true
+	for hasNextToken {
+		o, err := c.svc.ec2.DescribeManagedPrefixListsWithContext(ctx, input)
+		if err != nil {
+			return nil, err
+		}
+		if o.PrefixLists == nil {
+			hasNextToken = false
+			continue
+		}
+
+		if input == nil {
+			input = &ec2.DescribeManagedPrefixListsInput{}
+		}
+		input.NextToken = o.NextToken
+		hasNextToken = o.NextToken != nil
+
+		opt = append(opt, o.PrefixLists...)
+
+	}
+
+	return opt, nil
+}
+
 func (c *connector) GetTransitGateways(ctx context.Context, input *ec2.DescribeTransitGatewaysInput) ([]*ec2.TransitGateway, error) {
 	if c.svc.ec2 == nil {
 		c.svc.ec2 = ec2.New(c.svc.session)

aws/resources.go

@@ -84,6 +84,7 @@ const (
 	ECSCluster
 	ECSService
 	ECSTaskDefinition
+	EC2ManagedPrefixList
 	EC2TransitGateway
 	EC2TransitGatewayVPCAttachment
 	EC2TransitGatewayRouteTable
@@ -225,6 +226,7 @@ var (
 		ECSCluster:                                 cacheECSClusters,
 		ECSService:                                 ecsServices,
 		ECSTaskDefinition:                          ecsTaskDefinitions,
+		EC2ManagedPrefixList:                       ec2ManagedPrefixList,
 		EC2TransitGateway:                          ec2TransitGateways,
 		EC2TransitGatewayVPCAttachment:             ec2TransitGatewayVPCAttachment,
 		EC2TransitGatewayRouteTable:                cacheTransitGatewayRouteTables,
@@ -1280,6 +1282,26 @@ func ecsTaskDefinitions(ctx context.Context, a *aws, resourceType string, filter
 	return resources, nil
 }
 
+func ec2ManagedPrefixList(ctx context.Context, a *aws, resourceType string, filters *filter.Filter) ([]provider.Resource, error) {
+	managedPrefixList, err := a.awsr.GetManagedPrefixLists(ctx, nil)
+	if err != nil {
+		return nil, err
+	}
+
+	resources := make([]provider.Resource, 0)
+
+	for _, i := range managedPrefixList {
+		r, err := initializeResource(a, *i.PrefixListId, resourceType)
+		if err != nil {
+			return nil, err
+		}
+
+		resources = append(resources, r)
+	}
+
+	return resources, nil
+}
+
 func ec2TransitGateways(ctx context.Context, a *aws, resourceType string, filters *filter.Filter) ([]provider.Resource, error) {
 	transitGateways, err := a.awsr.GetTransitGateways(ctx, nil)
 	if err != nil {