in node/example/sample-deaggregation.js [33:53]
var handleNoProcess = function(event, callback) {
"use strict";
var noProcessReason;
if (!event.Records || event.Records.length === 0) {
noProcessReason = "Event contains no Data";
}
if (event.Records[0].eventSource !== "aws:kinesis") {
noProcessReason = "Invalid Event Source " + event.Records[0].eventSource;
}
if (event.Records[0].kinesis.kinesisSchemaVersion !== "1.0") {
noProcessReason = "Unsupported Event Schema Version " + event.Records[0].kinesis.kinesisSchemaVersion;
}
if (noProcessReason) {
finish(event, error, noProcessReason);
} else {
callback();
}
};