feat(aws): Add Support For Config Rules and Compliance (#4730)

#### Summary

<!--
Explain what problem this PR addresses
-->

<!--

plugins/source/aws/codegen/recipes/config.go

@@ -60,6 +60,26 @@ func ConfigResources() []*Resource {
 					},
 				}...),
 		},
+		{
+			SubService: "config_rules",
+			Struct:     new(types.ConfigRule),
+			SkipFields: []string{"ConfigRuleArn"},
+			ExtraColumns: append(defaultRegionalColumns,
+				[]codegen.ColumnDefinition{
+					{
+						Name:     "arn",
+						Type:     schema.TypeString,
+						Resolver: `schema.PathResolver("ConfigRuleArn")`,
+						Options:  schema.ColumnCreationOptions{PrimaryKey: true},
+					},
+				}...),
+			Relations: []string{"ConfigRuleCompliances()"},
+		},
+		{
+			SubService:   "config_rule_compliances",
+			Struct:       new(types.ComplianceByConfigRule),
+			ExtraColumns: defaultRegionalColumns,
+		},
 	}
 
 	// set default values

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

@@ -94,6 +94,8 @@
 | [aws_config_configuration_recorders](aws_config_configuration_recorders.md) |
 | [aws_config_conformance_packs](aws_config_conformance_packs.md) |
 | ↳ [aws_config_conformance_pack_rule_compliances](aws_config_conformance_pack_rule_compliances.md) |
+| [aws_config_config_rules](aws_config_config_rules.md) |
+| ↳ [aws_config_config_rule_compliances](aws_config_config_rule_compliances.md) |
 | [aws_dax_clusters](aws_dax_clusters.md) |
 | [aws_directconnect_connections](aws_directconnect_connections.md) |
 | [aws_directconnect_gateways](aws_directconnect_gateways.md) |

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

@@ -0,0 +1,20 @@
+# Table: aws_config_config_rule_compliances
+
+
+
+The primary key for this table is **_cq_id**.
+
+## Relations
+This table depends on [aws_config_config_rules](aws_config_config_rules.md).
+
+## Columns
+| Name          | Type          |
+| ------------- | ------------- |
+|_cq_source_name|String|
+|_cq_sync_time|Timestamp|
+|_cq_id (PK)|UUID|
+|_cq_parent_id|UUID|
+|account_id|String|
+|region|String|
+|compliance|JSON|
+|config_rule_name|String|

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

@@ -0,0 +1,29 @@
+# Table: aws_config_config_rules
+
+
+
+The primary key for this table is **arn**.
+
+## Relations
+The following tables depend on aws_config_config_rules:
+  - [aws_config_config_rule_compliances](aws_config_config_rule_compliances.md)
+
+## Columns
+| Name          | Type          |
+| ------------- | ------------- |
+|_cq_source_name|String|
+|_cq_sync_time|Timestamp|
+|_cq_id|UUID|
+|_cq_parent_id|UUID|
+|account_id|String|
+|region|String|
+|arn (PK)|String|
+|source|JSON|
+|config_rule_id|String|
+|config_rule_name|String|
+|config_rule_state|String|
+|created_by|String|
+|description|String|
+|input_parameters|String|
+|maximum_execution_frequency|String|
+|scope|JSON|

plugins/source/aws/resources/services/config/config_rule_compliances_fetch.go

@@ -0,0 +1,30 @@
+package config
+
+import (
+	"context"
+
+	"github.com/aws/aws-sdk-go-v2/aws"
+	"github.com/aws/aws-sdk-go-v2/service/configservice"
+	"github.com/aws/aws-sdk-go-v2/service/configservice/types"
+	"github.com/cloudquery/cloudquery/plugins/source/aws/client"
+	"github.com/cloudquery/plugin-sdk/schema"
+)
+
+func fetchConfigConfigRuleCompliances(ctx context.Context, meta schema.ClientMeta, parent *schema.Resource, res chan<- interface{}) error {
+	ruleDetail := parent.Item.(types.ConfigRule)
+	c := meta.(*client.Client)
+	svc := c.Services().Configservice
+
+	input := &configservice.DescribeComplianceByConfigRuleInput{
+		ConfigRuleNames: []string{aws.ToString(ruleDetail.ConfigRuleName)},
+	}
+	p := configservice.NewDescribeComplianceByConfigRulePaginator(svc, input)
+	for p.HasMorePages() {
+		response, err := p.NextPage(ctx)
+		if err != nil {
+			return err
+		}
+		res <- response.ComplianceByConfigRules
+	}
+	return nil
+}

plugins/source/aws/resources/services/config/config_rules_fetch.go

@@ -0,0 +1,25 @@
+package config
+
+import (
+	"context"
+
+	"github.com/aws/aws-sdk-go-v2/service/configservice"
+	"github.com/cloudquery/cloudquery/plugins/source/aws/client"
+	"github.com/cloudquery/plugin-sdk/schema"
+)
+
+func fetchConfigConfigRules(ctx context.Context, meta schema.ClientMeta, parent *schema.Resource, res chan<- interface{}) error {
+	c := meta.(*client.Client)
+	svc := c.Services().Configservice
+
+	input := &configservice.DescribeConfigRulesInput{}
+	p := configservice.NewDescribeConfigRulesPaginator(svc, input)
+	for p.HasMorePages() {
+		response, err := p.NextPage(ctx)
+		if err != nil {
+			return err
+		}
+		res <- response.ConfigRules
+	}
+	return nil
+}

plugins/source/aws/resources/services/config/config_rules_mock_test.go

@@ -0,0 +1,39 @@
+package config
+
+import (
+	"testing"
+
+	"github.com/aws/aws-sdk-go-v2/service/configservice"
+	"github.com/aws/aws-sdk-go-v2/service/configservice/types"
+	"github.com/cloudquery/cloudquery/plugins/source/aws/client"
+	"github.com/cloudquery/cloudquery/plugins/source/aws/client/mocks"
+	"github.com/cloudquery/plugin-sdk/faker"
+	"github.com/golang/mock/gomock"
+)
+
+func buildConfigRules(t *testing.T, ctrl *gomock.Controller) client.Services {
+	m := mocks.NewMockConfigserviceClient(ctrl)
+	l := types.ConfigRule{}
+	if err := faker.FakeObject(&l); err != nil {
+		t.Fatal(err)
+	}
+	sl := types.ComplianceByConfigRule{}
+	if err := faker.FakeObject(&sl); err != nil {
+		t.Fatal(err)
+	}
+	m.EXPECT().DescribeConfigRules(gomock.Any(), gomock.Any(), gomock.Any()).Return(
+		&configservice.DescribeConfigRulesOutput{
+			ConfigRules: []types.ConfigRule{l},
+		}, nil)
+	m.EXPECT().DescribeComplianceByConfigRule(gomock.Any(), gomock.Any(), gomock.Any()).Return(
+		&configservice.DescribeComplianceByConfigRuleOutput{
+			ComplianceByConfigRules: []types.ComplianceByConfigRule{sl},
+		}, nil)
+	return client.Services{
+		Configservice: m,
+	}
+}
+
+func TestConfigRules(t *testing.T) {
+	client.AwsMockTestHelper(t, ConfigRules(), buildConfigRules, client.TestOptions{})
+}