'use strict';
console.log('Loading function');

exports.handler = async (event, context) => {
    /* Process the list of records and transform them */
    const output = event.records.map((record) => {
        const entry = (new Buffer.from(record.data, 'base64')).toString('utf8');
        var json_data = JSON.parse(entry);
        json_data.event_timestamp   = new Date(json_data.event_timestamp).toISOString();
        json_data.arrival_timestamp = new Date(json_data.arrival_timestamp).toISOString();
        console.log(json_data);
        const result = JSON.stringify(json_data);
        const payload = (new Buffer.from(result, 'utf8')).toString('base64');

        /* Transformed event */
        return {
            recordId: record.recordId,
            result: 'Ok',
            data: payload,
        };
    });
    console.log(`Processing completed.  Successful records ${output.length}.`);
    console.log(output);
    return { records: output };
};