implementation.js

'use strict';

const delimiter = "\n";
const utils = require('./utils.js');

function transform(item) {
  // don't worry about this utils function, just look at transformProfile is doing,
  // receiving the streamData and creating an array of object literals with the atomic facts
  // we want to store
  return utils.arrayObjectToString(transformProfile(item), delimiter);  
}

function transformProfile(streamData) {
    return [
        {
            id: streamData['id'],
            event_name: 'accommodation_provider_updated_name',
            accommodation_provider_id: streamData['accommodation_provider_id'],
            field: 'name',
            value: streamData['profile']['name'],
            timestamp: streamData['timestamp']
        },
        {
            id: streamData['id'],
            event_name: 'accommodation_provider_updated_email_address',
            accommodation_provider_id: streamData['accommodation_provider_id'],
            field: 'email_address',
            value: streamData['profile']['email_address']['email_address'],
            timestamp: streamData['timestamp']
        },
    ];
}

exports.transform = transform;