function processPayload()

in lib/application/lambda/process-kinesis-event.js [19:24]

• 6 lines of code
• 1 McCabe index (conditional complexity)

function processPayload(record) {
    const payload = JSON.parse(Buffer.from(record.data, 'base64').toString('utf8'));
    const timestamp = new Date(record.kinesisRecordMetadata.approximateArrivalTimestamp).toISOString();
    const enrichedPayload = Object.assign({approximate_arrival_timestamp: timestamp}, payload);
    return Buffer.from(JSON.stringify(enrichedPayload)+"\n").toString('base64');
}