migrate sdk from v2 to v3 for listFailedObject

ISSUE : S3UTILS-202

Author: SylvainSenechal

listFailedObjects.js

@@ -1,6 +1,7 @@
 const async = require('async');
-const AWS = require('aws-sdk');
-const { http } = require('httpagent');
+const { S3Client, ListObjectVersionsCommand, HeadObjectCommand } = require('@aws-sdk/client-s3');
+const { NodeHttpHandler } = require('@aws-sdk/node-http-handler');
+const http = require('http');
 
 const { Logger } = require('werelogs');
 
@@ -32,31 +33,35 @@ if (!SECRET_KEY) {
     process.exit(1);
 }
 
-const s3 = new AWS.S3({
-    accessKeyId: ACCESS_KEY,
-    secretAccessKey: SECRET_KEY,
+const s3 = new S3Client({
     region: 'us-east-1',
-    sslEnabled: false,
-    endpoint: ENDPOINT,
-    s3ForcePathStyle: true,
-    apiVersions: { s3: '2006-03-01' },
-    signatureVersion: 'v4',
-    signatureCache: false,
-    httpOptions: {
-        maxRetries: 0,
-        timeout: 0,
-        agent: new http.Agent({ keepAlive: true }),
+    credentials: {
+        accessKeyId: ACCESS_KEY,
+        secretAccessKey: SECRET_KEY,
     },
+    endpoint: ENDPOINT,
+    forcePathStyle: true,
+    tls: false,
+    requestHandler: new NodeHttpHandler({
+        httpAgent: new http.Agent({ keepAlive: true }),
+        requestTimeout: 0,
+    }),
 });
 
 // list object versions
 function _listObjectVersions(bucket, VersionIdMarker, KeyMarker, cb) {
-    s3.listObjectVersions({
+    s3.send(new ListObjectVersionsCommand({
         Bucket: bucket,
         MaxKeys: LISTING_LIMIT,
         VersionIdMarker,
         KeyMarker,
-    }, cb);
+    }))
+        .then(data => {
+            cb(null, data);
+        })
+        .catch(err => {
+            cb(err);
+        });
 }
 
 // return object with key and version_id
@@ -82,21 +87,23 @@ function listBucket(bucket, cb) {
                     log.error('error occured while listing', { error: err, bucketName });
                     return done(err);
                 }
-                const keys = _getKeys(data.Versions);
+                const keys = _getKeys(data.Versions || []);
                 return async.mapLimit(keys, 10, (k, next) => {
                     const { Key, VersionId } = k;
-                    s3.headObject(
-                        { Bucket: bucketName, Key, VersionId },
-                        (err, res) => {
-                            if (err) {
-                                return next(err);
-                            }
+                    s3.send(new HeadObjectCommand({
+                        Bucket: bucketName,
+                        Key,
+                        VersionId,
+                    }))
+                        .then(res => {
                             if (res.ReplicationStatus === 'FAILED') {
                                 console.log({ Key, ...res });
                             }
                             return next();
-                        },
-                    );
+                        })
+                        .catch(err => {
+                            return next(err);
+                        });
                 }, err => {
                     if (err) {
                         return done(err);