🧹 aws resource fixes (#3083)

* 🐛 fix aws elb loadbalancer attributes

* 🧹 add dynamodb global table discovery

* 🧹 add log message for required namespace for aws applicationautoscaling

* 🧹 fixups

providers/aws/resources/aws_applicationautoscaling.go

@@ -31,6 +31,9 @@ func (a *mqlAwsApplicationautoscalingTarget) id() (string, error) {
 func (a *mqlAwsApplicationAutoscaling) scalableTargets() ([]interface{}, error) {
 	conn := a.MqlRuntime.Connection.(*connection.AwsConnection)
 	namespace := a.Namespace.Data
+	if namespace == "" {
+		return nil, errors.New("namespace required for application autoscaling query. please specify one of [comprehend, rds, sagemaker, appstream, elasticmapreduce, dynamodb, lambda, ecs, cassandra, ec2, neptune, kafka, custom-resource, elasticache]")
+	}
 
 	res := []interface{}{}
 	poolOfJobs := jobpool.CreatePool(a.getTargets(conn, aatypes.ServiceNamespace(namespace)), 5)

providers/aws/resources/aws_elb.go

@@ -7,9 +7,11 @@ import (
 	"context"
 	"errors"
 	"fmt"
+	"strings"
 
 	"github.com/aws/aws-sdk-go-v2/service/elasticloadbalancing"
 	"github.com/aws/aws-sdk-go-v2/service/elasticloadbalancingv2"
+	"github.com/aws/aws-sdk-go/aws/arn"
 	"github.com/rs/zerolog/log"
 	"go.mondoo.com/cnquery/v10/llx"
 	"go.mondoo.com/cnquery/v10/providers-sdk/v1/plugin"
@@ -215,8 +217,12 @@ func (a *mqlAwsElbLoadbalancer) listenerDescriptions() ([]interface{}, error) {
 	if err != nil {
 		return nil, err
 	}
-	svc := conn.Elbv2(region)
 	ctx := context.Background()
+
+	if isV1LoadBalancerArn(arn) {
+		return a.ListenerDescriptions.Data, nil
+	}
+	svc := conn.Elbv2(region)
 	listeners, err := svc.DescribeListeners(ctx, &elasticloadbalancingv2.DescribeListenersInput{LoadBalancerArn: &arn})
 	if err != nil {
 		return nil, err
@@ -227,16 +233,41 @@ func (a *mqlAwsElbLoadbalancer) listenerDescriptions() ([]interface{}, error) {
 func (a *mqlAwsElbLoadbalancer) attributes() ([]interface{}, error) {
 	conn := a.MqlRuntime.Connection.(*connection.AwsConnection)
 	arn := a.Arn.Data
+	name := a.Name.Data
 
 	region, err := GetRegionFromArn(arn)
 	if err != nil {
 		return nil, err
 	}
-	svc := conn.Elbv2(region)
 	ctx := context.Background()
+
+	if isV1LoadBalancerArn(arn) {
+		svc := conn.Elb(region)
+		attributes, err := svc.DescribeLoadBalancerAttributes(ctx, &elasticloadbalancing.DescribeLoadBalancerAttributesInput{LoadBalancerName: &name})
+		if err != nil {
+			return nil, err
+		}
+		j, err := convert.JsonToDict(attributes.LoadBalancerAttributes)
+		if err != nil {
+			return nil, err
+		}
+		return []interface{}{j}, nil
+	}
+	svc := conn.Elbv2(region)
 	attributes, err := svc.DescribeLoadBalancerAttributes(ctx, &elasticloadbalancingv2.DescribeLoadBalancerAttributesInput{LoadBalancerArn: &arn})
 	if err != nil {
 		return nil, err
 	}
 	return convert.JsonToDictSlice(attributes.Attributes)
 }
+
+func isV1LoadBalancerArn(a string) bool {
+	arnVal, err := arn.Parse(a)
+	if err != nil {
+		return false
+	}
+	if strings.Contains(arnVal.Resource, "classic") {
+		return true
+	}
+	return false
+}

providers/aws/resources/discovery.go

@@ -41,6 +41,7 @@ const (
 	DiscoveryCloudwatchLoggroups        = "cloudwatch-loggroups"
 	DiscoveryLambdaFunctions            = "lambda-functions"
 	DiscoveryDynamoDBTables             = "dynamodb-tables"
+	DiscoveryDynamoDBGlobalTables       = "dynamodb-global-tables"
 	DiscoveryRedshiftClusters           = "redshift-clusters"
 	DiscoveryVolumes                    = "ec2-volumes"
 	DiscoverySnapshots                  = "ec2-snapshots"
@@ -80,6 +81,7 @@ var AllAPIResources = []string{
 	DiscoveryCloudwatchLoggroups,
 	DiscoveryLambdaFunctions,
 	DiscoveryDynamoDBTables,
+	DiscoveryDynamoDBGlobalTables,
 	DiscoveryRedshiftClusters,
 	DiscoveryVolumes,
 	DiscoverySnapshots,
@@ -709,7 +711,15 @@ func discover(runtime *plugin.Runtime, awsAccount *mqlAwsAccount, target string,
 			}
 			assetList = append(assetList, MqlObjectToAsset(accountId, m, conn))
 		}
-		ts = d.GetGlobalTables()
+	case DiscoveryDynamoDBGlobalTables:
+		res, err := NewResource(runtime, "aws.dynamodb", map[string]*llx.RawData{})
+		if err != nil {
+			return nil, err
+		}
+
+		d := res.(*mqlAwsDynamodb)
+
+		ts := d.GetGlobalTables()
 		if ts == nil {
 			return assetList, nil
 		}