Script to delete/restore objects from S3

s3_delete_restore.txt

var AwsS3 = require ('aws-sdk/clients/s3');
let cred = {
    test: {
        "accessKeyId": "<test-key>",
        "secretAccessKey": "<test-secret>",
        "region": '<region>',
    },
    live: {
        "accessKeyId": "<live-key>",
        "secretAccessKey": "<live-secret>",
        "region": "<region>",
    }
};
const s3 = new AwsS3 (cred.test);

let config = {
    Bucket: "<bucket-name>"
};

async function listDirectories (prefix, marker)  {
    return new Promise ((resolve, reject) => {
        const s3params = {
            ...config,
            MaxKeys: 1000
        };
        if(prefix) {
            s3params['Prefix'] = prefix;
        }
        if(marker) {
            s3params['KeyMarker'] = marker;
        }
        s3.listObjectVersions (s3params, (err, data) => {
            if (err) {
                reject (err);
            }
            resolve (data);
        });
    });
}

async function deleteDirectory(Key, VersionId, action="restore"){
    return new Promise ((resolve, reject) => {
        const s3params = { ...config, Key, VersionId};
        if (action == "delete") delete s3params.Prefix;
        s3.deleteObject (s3params, (err, data) => {
            if (err) {
                reject (err);
            }
            resolve (data);
        });
    });
}

async function main(prefix, action="restore") {
    let deleteMarkers = [];
    let marker = "";
    let count=0;
    while (true) {
        count++;
        let listRes = await listDirectories(prefix, marker)
            .catch(err => console.log(err, `Unable to list Directories at ${count}th loop, Skipping...`));
        if (!listRes) continue;
        marker = decodeURIComponent(listRes.NextKeyMarker);
        if (action == "delete")
            deleteMarkers.push(...listRes.Versions);
        else if (action == "restore")
            deleteMarkers.push(...listRes.DeleteMarkers);
        console.log(`Loop Count :: ${count} , Next Marker :: ${ marker}`);
        if (!listRes.NextKeyMarker) break;
    }

    for (let i = 0 ; i < deleteMarkers.length ; i++) {
        await deleteDirectory(deleteMarkers[i].Key, deleteMarkers[i].VersionId, action)
            .then(data => console.log("Deleted Object :: ", deleteMarkers[i].Key))
            .catch(err => console.error("Error deleting Object :: ", err.message , " :: " , deleteMarkers[i].Key));
        
    }
}

main( "<prefix>", "restore");