S3 read / copy / delete file

S3 move file.js

const aws = require('aws-sdk');
const s3 = new aws.S3({apiVersion: '2006-03-01'});

const LambdaLog = require('lambda-log').LambdaLog;
const log = new LambdaLog({meta: {environment: process.env.ENVIRONMENT}});

async function deleteObject(bucket, currentPath) {

    var params = {
        Bucket: bucket,
        Delete: {
            Objects: [
                {
                    Key: currentPath
                }
            ]
        }
    };

    log.info(`Deleting file: ${JSON.stringify(params)}`);

    return s3.deleteObjects(params).promise();
}

async function copyToNewLocation(bucket, currentPath, updateId) {

    var params = {
        Bucket: bucket,
        Key: `updates/${updateId}/${Date.now()}`,
        CopySource: `${bucket}/${currentPath}`
    };

    log.info(`Copying file: ${JSON.stringify(params)}`);

    return s3.copyObject(params).promise();
}

var main = async (event, context, callback) => {
    aws.config.logger = console;
    log.info('Received event:', JSON.stringify(event, null, 2));

    const bucket = event.Records[0].s3.bucket.name;
    const key = decodeURIComponent(event.Records[0].s3.object.key.replace(/\+/g, ' '));

    const params = {
        Bucket: bucket,
        Key: key,
    };

    log.info("Event info: " + JSON.stringify(params));
    try {

        const data = await s3.getObject(params).promise();
        const content = data.Body.toString('UTF-8');

        let groupId = content.match(/Update Id: (\d+),/);        
      
        const copyRes = await copyToNewLocation(bucket, key, groupId[1]);
        const deleteRes = await deleteObject(bucket, key);
        callback(null, "Success");
      
    } catch (err) {
        const message = `Error getting object ${key} from bucket ${bucket}.`;
        log.error(message);

        callback(err);
    }
};

exports.handler = main;