transformVehicle.js

// Get just data under the value key on the consumed message
const vehicle_value = message.value.value;

// Flatten the nested JSON
const flattenedVehicle = {
    vehicle_id: vehicle_value.vehicle_id,
    location_latitude: vehicle_value.location.latitude,
    location_longitude: vehicle_value.location.longitude,
    ts: Date.now(),
    destination_latitude: vehicle_value.destination.latitude,
    destination_longitude: vehicle_value.destination.longitude,
    distanceRemaining: vehicle_value.distanceRemaining,
    ETA: vehicle_value.ETA
};

return flattenedVehicle;