feat(aws): Add support for Route53resolver service

plugins/source/aws/client/services.go

@@ -85,6 +85,7 @@ import (
 	"github.com/aws/aws-sdk-go-v2/service/resourcegroups"
 	"github.com/aws/aws-sdk-go-v2/service/route53"
 	"github.com/aws/aws-sdk-go-v2/service/route53domains"
+	"github.com/aws/aws-sdk-go-v2/service/route53resolver"
 	"github.com/aws/aws-sdk-go-v2/service/s3"
 	"github.com/aws/aws-sdk-go-v2/service/s3control"
 	"github.com/aws/aws-sdk-go-v2/service/sagemaker"
@@ -204,6 +205,7 @@ func initServices(c aws.Config, regions []string) Services {
 		Resourcegroups:            resourcegroups.NewFromConfig(awsCfg),
 		Route53:                   route53.NewFromConfig(awsCfg),
 		Route53domains:            route53domains.NewFromConfig(awsCfg),
+		Route53resolver:           route53resolver.NewFromConfig(awsCfg),
 		S3:                        s3.NewFromConfig(awsCfg),
 		S3control:                 s3control.NewFromConfig(awsCfg),
 		Sagemaker:                 sagemaker.NewFromConfig(awsCfg),
@@ -321,6 +323,7 @@ type Services struct {
 	Resiliencehub             services.ResiliencehubClient
 	Route53                   services.Route53Client
 	Route53domains            services.Route53domainsClient
+	Route53resolver           services.Route53resolverClient
 	S3                        services.S3Client
 	S3control                 services.S3controlClient
 	Sagemaker                 services.SagemakerClient

plugins/source/aws/codegen/main.go

@@ -88,6 +88,7 @@ import (
 	"github.com/aws/aws-sdk-go-v2/service/resourcegroups"
 	"github.com/aws/aws-sdk-go-v2/service/route53"
 	"github.com/aws/aws-sdk-go-v2/service/route53domains"
+	"github.com/aws/aws-sdk-go-v2/service/route53resolver"
 	"github.com/aws/aws-sdk-go-v2/service/s3"
 	"github.com/aws/aws-sdk-go-v2/service/s3control"
 	"github.com/aws/aws-sdk-go-v2/service/sagemaker"
@@ -205,6 +206,7 @@ var clients = []any{
 	&resourcegroups.Client{},
 	&route53.Client{},
 	&route53domains.Client{},
+	&route53resolver.Client{},
 	&s3.Client{},
 	&s3control.Client{},
 	&sagemaker.Client{},

plugins/source/aws/docs/tables/README.md

@@ -543,6 +543,15 @@
 - [aws_route53_operations](../../../../../website/tables/aws/aws_route53_operations.md)
 - [aws_route53_traffic_policies](../../../../../website/tables/aws/aws_route53_traffic_policies.md)
   - [aws_route53_traffic_policy_versions](../../../../../website/tables/aws/aws_route53_traffic_policy_versions.md)
+- [aws_route53resolver_firewall_configs](../../../../../website/tables/aws/aws_route53resolver_firewall_configs.md)
+- [aws_route53resolver_firewall_domain_lists](../../../../../website/tables/aws/aws_route53resolver_firewall_domain_lists.md)
+- [aws_route53resolver_firewall_rule_group_associations](../../../../../website/tables/aws/aws_route53resolver_firewall_rule_group_associations.md)
+- [aws_route53resolver_firewall_rule_groups](../../../../../website/tables/aws/aws_route53resolver_firewall_rule_groups.md)
+- [aws_route53resolver_resolver_endpoints](../../../../../website/tables/aws/aws_route53resolver_resolver_endpoints.md)
+- [aws_route53resolver_resolver_query_log_config_associations](../../../../../website/tables/aws/aws_route53resolver_resolver_query_log_config_associations.md)
+- [aws_route53resolver_resolver_query_log_configs](../../../../../website/tables/aws/aws_route53resolver_resolver_query_log_configs.md)
+- [aws_route53resolver_resolver_rule_associations](../../../../../website/tables/aws/aws_route53resolver_resolver_rule_associations.md)
+- [aws_route53resolver_resolver_rules](../../../../../website/tables/aws/aws_route53resolver_resolver_rules.md)
 - [aws_s3_access_points](../../../../../website/tables/aws/aws_s3_access_points.md)
 - [aws_s3_accounts](../../../../../website/tables/aws/aws_s3_accounts.md)
 - [aws_s3_buckets](../../../../../website/tables/aws/aws_s3_buckets.md)

plugins/source/aws/go.mod

@@ -90,6 +90,7 @@ require (
 	github.com/aws/aws-sdk-go-v2/service/resourcegroups v1.14.13
 	github.com/aws/aws-sdk-go-v2/service/route53 v1.28.3
 	github.com/aws/aws-sdk-go-v2/service/route53domains v1.15.0
+	github.com/aws/aws-sdk-go-v2/service/route53resolver v1.17.13
 	github.com/aws/aws-sdk-go-v2/service/s3 v1.35.0
 	github.com/aws/aws-sdk-go-v2/service/s3control v1.31.7
 	github.com/aws/aws-sdk-go-v2/service/sagemaker v1.86.0

plugins/source/aws/go.sum

@@ -251,6 +251,8 @@ github.com/aws/aws-sdk-go-v2/service/route53 v1.28.3 h1:nJbE4+tHd8xpM1RB1ZF0/xTJ
 github.com/aws/aws-sdk-go-v2/service/route53 v1.28.3/go.mod h1:Cd4MnFoV+6fELBrgWXJ4Y09FrSkn/VjNPkOr1Yr1muU=
 github.com/aws/aws-sdk-go-v2/service/route53domains v1.15.0 h1:H7c53dt/1Wsp3fWbu5v5+XVNsThWzmxzYdyYLltWtec=
 github.com/aws/aws-sdk-go-v2/service/route53domains v1.15.0/go.mod h1:k75fR3BhOo/0umex9ICEJ+CKTA55qxvFWAlyVHTS6Qg=
+github.com/aws/aws-sdk-go-v2/service/route53resolver v1.17.13 h1:Oa55ObrMEJV/ARzZbmsUaY4u7hCWO2LWOsn8KVr37J4=
+github.com/aws/aws-sdk-go-v2/service/route53resolver v1.17.13/go.mod h1:AEl0z7i/yOgN832f4yiVj6HudTkLOau55/Ckc8zxutA=
 github.com/aws/aws-sdk-go-v2/service/s3 v1.35.0 h1:ya7fmrN2fE7s1P2gaPbNg5MTkERVWfsH8ToP1YC4Z9o=
 github.com/aws/aws-sdk-go-v2/service/s3 v1.35.0/go.mod h1:aVbf0sko/TsLWHx30c/uVu7c62+0EAJ3vbxaJga0xCw=
 github.com/aws/aws-sdk-go-v2/service/s3control v1.31.7 h1:dTPOxNtrOt1NU/3DstjpNOAT7qjnMcZ08ah4A3zuu2w=

plugins/source/aws/resources/plugin/plugin.go

@@ -69,6 +69,8 @@ var awsExceptions = map[string]string{
 	"qldb":                   "Quantum Ledger Database (QLDB)",
 	"quicksight":             "QuickSight",
 	"rds":                    "Amazon Relational Database Service (RDS)",
+	"route53":                "Amazon Route 53",
+	"route53resolver":        "Amazon Route 53 Resolver",
 	"resiliencehub":          "AWS Resilience Hub",
 	"sagemaker":              "Amazon SageMaker",
 	"secretsmanager":         "AWS Secrets Manager",

plugins/source/aws/resources/plugin/tables.go

@@ -82,6 +82,7 @@ import (
 	"github.com/cloudquery/cloudquery/plugins/source/aws/resources/services/resiliencehub"
 	"github.com/cloudquery/cloudquery/plugins/source/aws/resources/services/resourcegroups"
 	"github.com/cloudquery/cloudquery/plugins/source/aws/resources/services/route53"
+	"github.com/cloudquery/cloudquery/plugins/source/aws/resources/services/route53resolver"
 	"github.com/cloudquery/cloudquery/plugins/source/aws/resources/services/s3"
 	"github.com/cloudquery/cloudquery/plugins/source/aws/resources/services/sagemaker"
 	"github.com/cloudquery/cloudquery/plugins/source/aws/resources/services/savingsplans"
@@ -463,6 +464,15 @@ func tables() []*schema.Table {
 		route53.HostedZones(),
 		route53.Operations(),
 		route53.TrafficPolicies(),
+		route53resolver.FirewallConfigs(),
+		route53resolver.FirewallDomainLists(),
+		route53resolver.FirewallRuleGroupAssociations(),
+		route53resolver.FirewallRuleGroups(),
+		route53resolver.ResolverEndpoints(),
+		route53resolver.ResolverQueryLogConfigAssociations(),
+		route53resolver.ResolverQueryLogConfigs(),
+		route53resolver.ResolverRuleAssociations(),
+		route53resolver.ResolverRules(),
 		s3.AccessPoints(),
 		s3.Accounts(),
 		s3.Buckets(),

plugins/source/aws/resources/services/route53resolver/firewall_configs.go

@@ -0,0 +1,43 @@
+package route53resolver
+
+import (
+	"context"
+
+	"github.com/aws/aws-sdk-go-v2/service/route53resolver"
+	"github.com/aws/aws-sdk-go-v2/service/route53resolver/types"
+	"github.com/cloudquery/cloudquery/plugins/source/aws/client"
+	"github.com/cloudquery/plugin-sdk/v3/schema"
+	"github.com/cloudquery/plugin-sdk/v3/transformers"
+)
+
+func FirewallConfigs() *schema.Table {
+	tableName := "aws_route53resolver_firewall_configs"
+	return &schema.Table{
+		Name:        tableName,
+		Description: `https://docs.aws.amazon.com/Route53/latest/APIReference/API_route53resolver_FirewallConfig.html`,
+		Resolver:    fetchFirewallConfigs,
+		Transform:   transformers.TransformWithStruct(&types.FirewallConfig{}, transformers.WithPrimaryKeys("Id")),
+		Multiplex:   client.ServiceAccountRegionMultiplexer(tableName, "route53resolver"),
+		Columns: []schema.Column{
+			client.DefaultAccountIDColumn(true),
+			client.DefaultRegionColumn(true),
+		},
+	}
+}
+
+func fetchFirewallConfigs(ctx context.Context, meta schema.ClientMeta, parent *schema.Resource, res chan<- any) error {
+	cl := meta.(*client.Client)
+	svc := cl.Services().Route53resolver
+	var input route53resolver.ListFirewallConfigsInput
+	paginator := route53resolver.NewListFirewallConfigsPaginator(svc, &input)
+	for paginator.HasMorePages() {
+		page, err := paginator.NextPage(ctx, func(options *route53resolver.Options) {
+			options.Region = cl.Region
+		})
+		if err != nil {
+			return err
+		}
+		res <- page.FirewallConfigs
+	}
+	return nil
+}

plugins/source/aws/resources/services/route53resolver/firewall_configs_mock_test.go

@@ -0,0 +1,31 @@
+package route53resolver
+
+import (
+	"testing"
+
+	"github.com/aws/aws-sdk-go-v2/service/route53resolver"
+	"github.com/aws/aws-sdk-go-v2/service/route53resolver/types"
+	"github.com/cloudquery/cloudquery/plugins/source/aws/client"
+	"github.com/cloudquery/cloudquery/plugins/source/aws/client/mocks"
+	"github.com/cloudquery/plugin-sdk/v3/faker"
+	"github.com/golang/mock/gomock"
+	"github.com/stretchr/testify/require"
+)
+
+func buildFirewallConfigsMock(t *testing.T, ctrl *gomock.Controller) client.Services {
+	m := mocks.NewMockRoute53resolverClient(ctrl)
+	fc := types.FirewallConfig{}
+	require.NoError(t, faker.FakeObject(&fc))
+
+	m.EXPECT().ListFirewallConfigs(gomock.Any(), gomock.Any(), gomock.Any()).Return(
+		&route53resolver.ListFirewallConfigsOutput{
+			FirewallConfigs: []types.FirewallConfig{fc},
+		}, nil)
+
+	return client.Services{
+		Route53resolver: m,
+	}
+}
+func TestFirewallConfigs(t *testing.T) {
+	client.AwsMockTestHelper(t, FirewallConfigs(), buildFirewallConfigsMock, client.TestOptions{})
+}

plugins/source/aws/resources/services/route53resolver/firewall_domain_list.go

@@ -0,0 +1,60 @@
+package route53resolver
+
+import (
+	"context"
+
+	"github.com/aws/aws-sdk-go-v2/service/route53resolver"
+	"github.com/aws/aws-sdk-go-v2/service/route53resolver/types"
+	"github.com/cloudquery/cloudquery/plugins/source/aws/client"
+	"github.com/cloudquery/plugin-sdk/v3/schema"
+	"github.com/cloudquery/plugin-sdk/v3/transformers"
+)
+
+func FirewallDomainLists() *schema.Table {
+	tableName := "aws_route53resolver_firewall_domain_lists"
+	return &schema.Table{
+		Name:                tableName,
+		Description:         `https://docs.aws.amazon.com/Route53/latest/APIReference/API_route53resolver_FirewallDomainList.html`,
+		Resolver:            fetchFirewallDomainList,
+		PreResourceResolver: getFirewallDomainList,
+		Transform:           transformers.TransformWithStruct(&types.FirewallDomainList{}, transformers.WithPrimaryKeys("Arn")),
+		Multiplex:           client.ServiceAccountRegionMultiplexer(tableName, "route53resolver"),
+		Columns: []schema.Column{
+			client.DefaultAccountIDColumn(false),
+			client.DefaultRegionColumn(false),
+		},
+	}
+}
+
+func fetchFirewallDomainList(ctx context.Context, meta schema.ClientMeta, parent *schema.Resource, res chan<- any) error {
+	cl := meta.(*client.Client)
+	svc := cl.Services().Route53resolver
+	var input route53resolver.ListFirewallDomainListsInput
+	paginator := route53resolver.NewListFirewallDomainListsPaginator(svc, &input)
+	for paginator.HasMorePages() {
+		page, err := paginator.NextPage(ctx, func(options *route53resolver.Options) {
+			options.Region = cl.Region
+		})
+		if err != nil {
+			return err
+		}
+		res <- page.FirewallDomainLists
+	}
+	return nil
+}
+func getFirewallDomainList(ctx context.Context, meta schema.ClientMeta, resource *schema.Resource) error {
+	cl := meta.(*client.Client)
+	svc := cl.Services().Route53resolver
+	v := resource.Item.(types.FirewallDomainListMetadata)
+
+	d, err := svc.GetFirewallDomainList(ctx, &route53resolver.GetFirewallDomainListInput{FirewallDomainListId: v.Id}, func(options *route53resolver.Options) {
+		options.Region = cl.Region
+	})
+	if err != nil {
+		return err
+	}
+
+	resource.Item = d.FirewallDomainList
+
+	return nil
+}

plugins/source/aws/resources/services/route53resolver/firewall_domain_list_mock_test.go

@@ -0,0 +1,39 @@
+package route53resolver
+
+import (
+	"testing"
+
+	"github.com/aws/aws-sdk-go-v2/service/route53resolver"
+	"github.com/aws/aws-sdk-go-v2/service/route53resolver/types"
+	"github.com/cloudquery/cloudquery/plugins/source/aws/client"
+	"github.com/cloudquery/cloudquery/plugins/source/aws/client/mocks"
+	"github.com/cloudquery/plugin-sdk/v3/faker"
+	"github.com/golang/mock/gomock"
+	"github.com/stretchr/testify/require"
+)
+
+func buildFirewallDomainListMock(t *testing.T, ctrl *gomock.Controller) client.Services {
+	m := mocks.NewMockRoute53resolverClient(ctrl)
+	fdlm := types.FirewallDomainListMetadata{}
+	require.NoError(t, faker.FakeObject(&fdlm))
+
+	m.EXPECT().ListFirewallDomainLists(gomock.Any(), gomock.Any(), gomock.Any()).Return(
+		&route53resolver.ListFirewallDomainListsOutput{
+			FirewallDomainLists: []types.FirewallDomainListMetadata{fdlm},
+		}, nil)
+
+	fdl := types.FirewallDomainList{}
+	require.NoError(t, faker.FakeObject(&fdl))
+
+	m.EXPECT().GetFirewallDomainList(gomock.Any(), gomock.Any(), gomock.Any()).Return(
+		&route53resolver.GetFirewallDomainListOutput{
+			FirewallDomainList: &fdl,
+		}, nil)
+
+	return client.Services{
+		Route53resolver: m,
+	}
+}
+func TestFirewallDomainList(t *testing.T) {
+	client.AwsMockTestHelper(t, FirewallDomainLists(), buildFirewallDomainListMock, client.TestOptions{})
+}

plugins/source/aws/resources/services/route53resolver/firewall_rule_group_associations.go

@@ -0,0 +1,43 @@
+package route53resolver
+
+import (
+	"context"
+
+	"github.com/aws/aws-sdk-go-v2/service/route53resolver"
+	"github.com/aws/aws-sdk-go-v2/service/route53resolver/types"
+	"github.com/cloudquery/cloudquery/plugins/source/aws/client"
+	"github.com/cloudquery/plugin-sdk/v3/schema"
+	"github.com/cloudquery/plugin-sdk/v3/transformers"
+)
+
+func FirewallRuleGroupAssociations() *schema.Table {
+	tableName := "aws_route53resolver_firewall_rule_group_associations"
+	return &schema.Table{
+		Name:        tableName,
+		Description: `https://docs.aws.amazon.com/Route53/latest/APIReference/API_route53resolver_FirewallRuleGroupAssociation.html`,
+		Resolver:    fetchFirewallRuleGroupAssociations,
+		Transform:   transformers.TransformWithStruct(&types.FirewallRuleGroupAssociation{}, transformers.WithPrimaryKeys("Arn")),
+		Multiplex:   client.ServiceAccountRegionMultiplexer(tableName, "route53resolver"),
+		Columns: []schema.Column{
+			client.DefaultAccountIDColumn(false),
+			client.DefaultRegionColumn(false),
+		},
+	}
+}
+
+func fetchFirewallRuleGroupAssociations(ctx context.Context, meta schema.ClientMeta, parent *schema.Resource, res chan<- any) error {
+	cl := meta.(*client.Client)
+	svc := cl.Services().Route53resolver
+	var input route53resolver.ListFirewallRuleGroupAssociationsInput
+	paginator := route53resolver.NewListFirewallRuleGroupAssociationsPaginator(svc, &input)
+	for paginator.HasMorePages() {
+		page, err := paginator.NextPage(ctx, func(options *route53resolver.Options) {
+			options.Region = cl.Region
+		})
+		if err != nil {
+			return err
+		}
+		res <- page.FirewallRuleGroupAssociations
+	}
+	return nil
+}