exports.transformRecords = function()

in lib/transformation.js [130:152]

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

exports.transformRecords = function(sourceRecords, target, callback) {
  async.map(sourceRecords, function(record, recordCallback) {
    if(record.eventSource == "aws:kinesis") {
      if(target.deaggregate) {
        transformKinesisAggregatedRecords(record, target, recordCallback);
      } else {
        transformKinesisSingleRecord(record, target, recordCallback);
      }
    } else if(record.eventSource == "aws:dynamodb") {
      transformDDBRecord(record, target, recordCallback);
    } else if(record.EventSource == "aws:sns") {
      transformSNSRecord(record, target, recordCallback);
    }
  }, function(err, results) {
    if(err) {
      console.error("Error occured while transforming records:", err);
      callback(null, []);
    } else {
      // Flatten the structure
      callback(null, [].concat.apply([], results));
    }
  });
}