migrating to aws sdk v3

clients.spec.js

@@ -0,0 +1,119 @@
+const assert = require('assert');
+const awsClients = [
+    '@aws-sdk/client-accessanalyzer',
+    '@aws-sdk/client-acm',
+    '@aws-sdk/client-api-gateway',
+    '@aws-sdk/client-apigatewayv2',
+    '@aws-sdk/client-apprunner',
+    '@aws-sdk/client-athena',
+    '@aws-sdk/client-auditmanager',
+    '@aws-sdk/client-auto-scaling',
+    '@aws-sdk/client-backup',
+    '@aws-sdk/client-appconfig',
+    '@aws-sdk/client-cloudformation',
+    '@aws-sdk/client-cognito-identity-provider',
+    '@aws-sdk/client-comprehend',
+    '@aws-sdk/client-compute-optimizer',
+    '@aws-sdk/client-config-service',
+    '@aws-sdk/client-sts',
+    '@aws-sdk/client-bedrock',
+    '@aws-sdk/client-s3',
+    '@aws-sdk/client-dynamodb',
+    '@aws-sdk/client-ec2',
+    '@aws-sdk/client-lambda',
+    '@aws-sdk/client-rds',
+    '@aws-sdk/client-sns',
+    '@aws-sdk/client-sqs',
+    '@aws-sdk/client-iam',
+    '@aws-sdk/client-cloudwatch',
+    '@aws-sdk/client-cloudfront',
+    '@aws-sdk/client-codebuild',
+    '@aws-sdk/client-customer-profiles',
+    '@aws-sdk/client-connect',
+    '@aws-sdk/client-database-migration-service',
+    '@aws-sdk/client-devops-guru',
+    '@aws-sdk/client-route-53',
+    '@aws-sdk/client-route-53-domains',
+    '@aws-sdk/client-waf-regional',
+    '@aws-sdk/client-waf',
+    '@aws-sdk/client-cloudtrail',
+    '@aws-sdk/client-timestream-write',
+    '@aws-sdk/client-redshift',
+    '@aws-sdk/client-docdb',
+    '@aws-sdk/client-neptune',
+    '@aws-sdk/client-elasticache',
+    '@aws-sdk/client-memorydb',
+    '@aws-sdk/client-kendra',
+    '@aws-sdk/client-qldb',
+    '@aws-sdk/client-efs',
+    '@aws-sdk/client-glacier',
+    '@aws-sdk/client-kms',
+    '@aws-sdk/client-secrets-manager',
+    '@aws-sdk/client-cloudwatch-logs',
+    '@aws-sdk/client-eventbridge',
+    '@aws-sdk/client-app-mesh',
+    '@aws-sdk/client-emr',
+    '@aws-sdk/client-codeartifact',
+    '@aws-sdk/client-codepipeline',
+    '@aws-sdk/client-ssm',
+    '@aws-sdk/client-sagemaker',
+    '@aws-sdk/client-proton',
+    '@aws-sdk/client-organizations',
+    '@aws-sdk/client-mwaa',
+    '@aws-sdk/client-managedblockchain',
+    '@aws-sdk/client-lookoutvision',
+    '@aws-sdk/client-lookoutequipment',
+    '@aws-sdk/client-lookoutmetrics',
+    '@aws-sdk/client-location',
+    '@aws-sdk/client-lex-models-v2',
+    '@aws-sdk/client-kinesis-video',
+    '@aws-sdk/client-dax',
+    '@aws-sdk/client-ecr',
+    '@aws-sdk/client-ecs',
+    '@aws-sdk/client-eks',
+    '@aws-sdk/client-elastic-beanstalk',
+    '@aws-sdk/client-elastic-transcoder',
+    '@aws-sdk/client-elastic-load-balancing',
+    '@aws-sdk/client-elastic-load-balancing-v2',
+    '@aws-sdk/client-finspace',
+    '@aws-sdk/client-firehose',
+    '@aws-sdk/client-forecast',
+    '@aws-sdk/client-frauddetector',
+    '@aws-sdk/client-fsx',
+    '@aws-sdk/client-glue',
+    '@aws-sdk/client-databrew',
+    '@aws-sdk/client-guardduty',
+    '@aws-sdk/client-healthlake',
+    '@aws-sdk/client-imagebuilder',
+    '@aws-sdk/client-iotsitewise',
+    '@aws-sdk/client-kinesis',
+    '@aws-sdk/client-mq',
+    '@aws-sdk/client-kafka',
+    '@aws-sdk/client-opensearch',
+    '@aws-sdk/client-opensearchserverless',
+    '@aws-sdk/client-securityhub',
+    '@aws-sdk/client-ses',
+    '@aws-sdk/client-shield',
+    '@aws-sdk/client-transfer',
+    '@aws-sdk/client-translate',
+    '@aws-sdk/client-wafv2',
+    '@aws-sdk/client-workspaces',
+    '@aws-sdk/client-xray',
+    '@aws-sdk/client-appflow',
+    '@aws-sdk/client-dlm',
+    '@aws-sdk/client-resource-groups-tagging-api',
+    '@aws-sdk/client-voice-id',
+    '@aws-sdk/client-wisdom'
+];
+
+describe('AWS SDK Clients', function () {
+    awsClients.forEach(client => {
+        it(`should have ${client} installed`, function () {
+            try {
+                require(client);
+            } catch (err) {
+                assert.fail(`${client} is not installed`);
+            }
+        });
+    });
+});

collectors/aws/accessanalyzer/listFindings.js

@@ -1,9 +1,11 @@
-var AWS = require('aws-sdk');
+const {
+    AccessAnalyzer
+} = require('@aws-sdk/client-accessanalyzer');
 var async = require('async');
 var helpers = require(__dirname + '/../../../helpers/aws');
 
 module.exports = function(AWSConfig, collection, retries, callback) {
-    var accessanalyzer = new AWS.AccessAnalyzer(AWSConfig);
+    var accessanalyzer = new AccessAnalyzer(AWSConfig);
     async.eachLimit(collection.accessanalyzer.listAnalyzers[AWSConfig.region].data, 15, function(analyzer, cb) {
         collection.accessanalyzer.listFindings[AWSConfig.region][analyzer.arn] = {};
         var params = {

collectors/aws/accessanalyzer/listFindingsV2.js

@@ -1,9 +1,11 @@
-var AWS = require('aws-sdk');
+const {
+    AccessAnalyzer
+} = require('@aws-sdk/client-accessanalyzer');
 var async = require('async');
 var helpers = require(__dirname + '/../../../helpers/aws');
 
 module.exports = function(AWSConfig, collection, retries, callback) {
-    var accessanalyzer = new AWS.AccessAnalyzer(AWSConfig);
+    var accessanalyzer = new AccessAnalyzer(AWSConfig);
     async.eachLimit(collection.accessanalyzer.listAnalyzers[AWSConfig.region].data, 15, function(analyzer, cb) {
         collection.accessanalyzer.listFindingsV2[AWSConfig.region][analyzer.arn] = {};
         var params = {

collectors/aws/apigateway/getClientCertificate.js

@@ -1,9 +1,11 @@
-var AWS = require('aws-sdk');
+const {
+    APIGateway
+} = require('@aws-sdk/client-api-gateway');
 var async = require('async');
 var helpers = require(__dirname + '/../../../helpers/aws');
 
 module.exports = function(AWSConfig, collection, retries, callback) {
-    var apigateway = new AWS.APIGateway(AWSConfig);
+    var apigateway = new APIGateway(AWSConfig);
 
     async.eachLimit(collection.apigateway.getRestApis[AWSConfig.region].data, 5, function(api, cb){
         if (!collection.apigateway.getStages ||

collectors/aws/apigateway/getIntegration.js

@@ -1,9 +1,11 @@
-var AWS = require('aws-sdk');
+const {
+    APIGateway
+} = require('@aws-sdk/client-api-gateway');
 var async = require('async');
 var helpers = require(__dirname + '/../../../helpers/aws');
 
 module.exports = function(AWSConfig, collection, retries, callback) {
-    var apigateway = new AWS.APIGateway(AWSConfig);
+    var apigateway = new APIGateway(AWSConfig);
 
     async.eachLimit(collection.apigateway.getRestApis[AWSConfig.region].data, 5, function(api, cb){
         if (!collection.apigateway.getResources ||

collectors/aws/appmesh/describeVirtualGateway.js

@@ -1,9 +1,11 @@
-var AWS = require('aws-sdk');
+const {
+    AppMesh
+} = require('@aws-sdk/client-app-mesh');
 var async = require('async');
 var helpers = require(__dirname + '/../../../helpers/aws');
 
 module.exports = function(AWSConfig, collection, retries, callback) {
-    var appmesh = new AWS.AppMesh(AWSConfig);
+    var appmesh = new AppMesh(AWSConfig);
 
     if (!collection.appmesh ||
         !collection.appmesh.listMeshes ||

collectors/aws/autoscaling/describeLaunchConfigurations.js

@@ -1,9 +1,11 @@
-var AWS = require('aws-sdk');
+const {
+    AutoScaling
+} = require('@aws-sdk/client-auto-scaling');
 var async = require('async');
 var helpers = require(__dirname + '/../../../helpers/aws');
 
 module.exports = function(AWSConfig, collection, retries, callback) {
-    var autoscaling = new AWS.AutoScaling(AWSConfig);
+    var autoscaling = new AutoScaling(AWSConfig);
 
     async.eachLimit(collection.autoscaling.describeAutoScalingGroups[AWSConfig.region].data, 15, function(asg, cb){
         collection.autoscaling.describeLaunchConfigurations[AWSConfig.region][asg.AutoScalingGroupARN] = {};

collectors/aws/autoscaling/describeNotificationConfigurations.js

@@ -1,9 +1,11 @@
-var AWS = require('aws-sdk');
+const {
+    AutoScaling
+} = require('@aws-sdk/client-auto-scaling');
 var async = require('async');
 var helpers = require(__dirname + '/../../../helpers/aws');
 
 module.exports = function(AWSConfig, collection, retries, callback) {
-    var autoscaling = new AWS.AutoScaling(AWSConfig);
+    var autoscaling = new AutoScaling(AWSConfig);
 
     async.eachLimit(collection.autoscaling.describeAutoScalingGroups[AWSConfig.region].data, 15, function(asg, cb){        
         var params = {

collectors/aws/cloudfront/getDistribution.js

@@ -1,9 +1,11 @@
-var AWS = require('aws-sdk');
+const {
+    CloudFront
+} = require('@aws-sdk/client-cloudfront');
 var async = require('async');
 var helpers = require(__dirname + '/../../../helpers/aws');
 
 module.exports = function(AWSConfig, collection, retries, callback) {
-    var cloudfront = new AWS.CloudFront(AWSConfig);
+    var cloudfront = new CloudFront(AWSConfig);
 
     async.eachLimit(collection.cloudfront.listDistributions[AWSConfig.region].data, 15, function(distribution, cb){        
         collection.cloudfront.getDistribution[AWSConfig.region][distribution.Id] = {};

collectors/aws/cloudtrail/listTags.js

@@ -1,9 +1,11 @@
-var AWS = require('aws-sdk');
+const {
+    CloudTrail
+} = require('@aws-sdk/client-cloudtrail');
 var async = require('async');
 var helpers = require(__dirname + '/../../../helpers/aws');
 
 module.exports = function(AWSConfig, collection, retries, callback) {
-    var cloudtrail = new AWS.CloudTrail(AWSConfig);
+    var cloudtrail = new CloudTrail(AWSConfig);
 
     async.eachLimit(collection.cloudtrail.describeTrails[AWSConfig.region].data, 15, function(trail, cb) {
         var params = {

collectors/aws/cloudwatch/getEc2MetricStatistics.js

@@ -1,9 +1,11 @@
-var AWS = require('aws-sdk');
+const {
+    CloudWatch
+} = require('@aws-sdk/client-cloudwatch');
 var async = require('async');
 var helpers = require('../../../helpers/aws');
 
 module.exports = function(AWSConfig, collection, retries, callback) {
-    var cloudwatch = new AWS.CloudWatch(AWSConfig);
+    var cloudwatch = new CloudWatch(AWSConfig);
 
     async.eachLimit(collection.ec2.describeInstances[AWSConfig.region].data, 10, function(reservation, cb) {
         reservation.Instances.forEach(instance => {
@@ -14,8 +16,8 @@ module.exports = function(AWSConfig, collection, retries, callback) {
             var params = {
                 'MetricName': 'CPUUtilization',
                 'Namespace': 'AWS/EC2',
-                'StartTime': startTime.toISOString(),
-                'EndTime': endTime.toISOString(),
+                'StartTime': startTime,
+                'EndTime': endTime,
                 'Period': 3600,
                 'Statistics': ['Average'],
                 'Dimensions': [

collectors/aws/cloudwatch/getEcMetricStatistics.js

@@ -1,9 +1,11 @@
-var AWS = require('aws-sdk');
+const {
+    CloudWatch
+} = require('@aws-sdk/client-cloudwatch');
 var async = require('async');
 var helpers = require(__dirname + '/../../../helpers/aws');
 
 module.exports = function(AWSConfig, collection, retries, callback) {
-    var cloudwatch = new AWS.CloudWatch(AWSConfig);
+    var cloudwatch = new CloudWatch(AWSConfig);
 
     async.eachLimit(collection.elasticache.describeCacheClusters[AWSConfig.region].data, 10, function(cluster, cb){        
         collection.cloudwatch.getEcMetricStatistics[AWSConfig.region][cluster.CacheClusterId] = {};
@@ -13,8 +15,8 @@ module.exports = function(AWSConfig, collection, retries, callback) {
         var params = {
             'MetricName': 'CPUUtilization',
             'Namespace':'AWS/ElastiCache',
-            'StartTime': startTime.toISOString(),
-            'EndTime': endTime.toISOString(),
+            'StartTime': startTime,
+            'EndTime': endTime,
             'Period': 3600,
             'Statistics': ['Average'],
             'Dimensions' : [

collectors/aws/cloudwatch/getEsMetricStatistics.js

@@ -1,9 +1,11 @@
-var AWS = require('aws-sdk');
+const {
+    CloudWatch
+} = require('@aws-sdk/client-cloudwatch');
 var async = require('async');
 var helpers = require(__dirname + '/../../../helpers/aws');
 
 module.exports = function(AWSConfig, collection, retries, callback) {
-    var cloudwatch = new AWS.CloudWatch(AWSConfig);
+    var cloudwatch = new CloudWatch(AWSConfig);
 
     async.eachLimit(collection.opensearch.listDomainNames[AWSConfig.region].data, 10, function(domain, cb){        
         collection.cloudwatch.getEsMetricStatistics[AWSConfig.region][domain.DomainName] = {};
@@ -13,8 +15,8 @@ module.exports = function(AWSConfig, collection, retries, callback) {
         var params = {
             'MetricName': 'ClusterStatus.Red',
             'Namespace':'AWS/ES',
-            'StartTime': startTime.toISOString(),
-            'EndTime': endTime.toISOString(),
+            'StartTime': startTime,
+            'EndTime': endTime,
             'Period': 3600,
             'Statistics': ['Maximum'],
             'Dimensions' : [

collectors/aws/cloudwatch/getRdsMetricStatistics.js

@@ -1,9 +1,11 @@
-var AWS = require('aws-sdk');
+const {
+    CloudWatch
+} = require('@aws-sdk/client-cloudwatch');
 var async = require('async');
 var helpers = require(__dirname + '/../../../helpers/aws');
 
 module.exports = function(AWSConfig, collection, retries, callback) {
-    var cloudwatch = new AWS.CloudWatch(AWSConfig);
+    var cloudwatch = new CloudWatch(AWSConfig);
 
     async.eachLimit(collection.rds.describeDBInstances[AWSConfig.region].data, 10, function(instance, cb){        
         collection.cloudwatch.getRdsMetricStatistics[AWSConfig.region][instance.DBInstanceIdentifier] = {};
@@ -13,8 +15,8 @@ module.exports = function(AWSConfig, collection, retries, callback) {
         var params = {
             'MetricName': 'CPUUtilization',
             'Namespace':'AWS/RDS',
-            'StartTime': startTime.toISOString(),
-            'EndTime': endTime.toISOString(),
+            'StartTime': startTime,
+            'EndTime': endTime,
             'Period': 86400,
             'Statistics': ['Average'],
             'Dimensions' : [

collectors/aws/cloudwatch/getRdsReadIOPSMetricStatistics.js

@@ -1,9 +1,11 @@
-var AWS = require('aws-sdk');
+const {
+    CloudWatch
+} = require('@aws-sdk/client-cloudwatch');
 var async = require('async');
 var helpers = require(__dirname + '/../../../helpers/aws');
 
 module.exports = function(AWSConfig, collection, retries, callback) {
-    var cloudwatch = new AWS.CloudWatch(AWSConfig);
+    var cloudwatch = new CloudWatch(AWSConfig);
 
     async.eachLimit(collection.rds.describeDBInstances[AWSConfig.region].data, 10, function(instance, cb){        
         collection.cloudwatch.getRdsReadIOPSMetricStatistics[AWSConfig.region][instance.DBInstanceIdentifier] = {};
@@ -13,8 +15,8 @@ module.exports = function(AWSConfig, collection, retries, callback) {
         var params = {
             'MetricName': 'ReadIOPS',
             'Namespace':'AWS/RDS',
-            'StartTime': startTime.toISOString(),
-            'EndTime': endTime.toISOString(),
+            'StartTime': startTime,
+            'EndTime': endTime,
             'Period': 86400,
             'Statistics': ['Sum'],
             'Dimensions' : [

collectors/aws/cloudwatch/getRdsWriteIOPSMetricStatistics.js

@@ -1,9 +1,11 @@
-var AWS = require('aws-sdk');
+const {
+    CloudWatch
+} = require('@aws-sdk/client-cloudwatch');
 var async = require('async');
 var helpers = require(__dirname + '/../../../helpers/aws');
 
 module.exports = function(AWSConfig, collection, retries, callback) {
-    var cloudwatch = new AWS.CloudWatch(AWSConfig);
+    var cloudwatch = new CloudWatch(AWSConfig);
 
     async.eachLimit(collection.rds.describeDBInstances[AWSConfig.region].data, 10, function(instance, cb){        
         collection.cloudwatch.getRdsWriteIOPSMetricStatistics[AWSConfig.region][instance.DBInstanceIdentifier] = {};
@@ -13,8 +15,8 @@ module.exports = function(AWSConfig, collection, retries, callback) {
         var params = {
             'MetricName': 'WriteIOPS',
             'Namespace':'AWS/RDS',
-            'StartTime': startTime.toISOString(),
-            'EndTime': endTime.toISOString(),
+            'StartTime': startTime,
+            'EndTime': endTime,
             'Period': 86400,
             'Statistics': ['Sum'],
             'Dimensions' : [