in src/RecordTransformer.js [52:69]
transformRecord(record, attributes) {
util.assertAttributes(record, 'eventName', 'eventSourceARN', 'dynamodb');
assert(record.eventSource === 'aws:dynamodb', `event source should be aws:dynamodb, but is ${record.eventSource}`);
const change = record.dynamodb;
const result = getPrimaryKeys(change, this.arnToKeyStructureMap[record.eventSourceARN]);
result.TableName = dynamodb.getTableNameFromArn(record.eventSourceARN);
result.EventName = record.eventName;
result.NewImage = change.NewImage;
result.OldImage = change.OldImage;
result.Timestamp = change.ApproximateCreationDateTime;
result.SequenceNumber = change.SequenceNumber;
if (change.NewImage !== undefined) {
extractAttributeValues(change.NewImage, attributes, result);
}
return result;
};