| 1 | ;
|
| 2 | Object.defineProperty(exports, "__esModule", { value: true });
|
| 3 | exports.dynamodbStream = void 0;
|
| 4 | const parser_1 = require("./parser");
|
| 5 | const common_1 = require("../common");
|
| 6 | const responses_1 = require("./responses");
|
| 7 | const metrics = new common_1.Metrics('DynamoDB Stream');
|
| 8 | function dynamodbStream(custom) {
|
| 9 | return function handler(event, context, callback) {
|
| 10 | const { newVersions, oldVersions, versions } = new parser_1.DynamoDBStreamParser(event).getVersions();
|
| 11 | metrics.common({ newVersions, oldVersions, versions });
|
| 12 | return custom({ event, newVersions, oldVersions, versions, success: responses_1.success, error: responses_1.error });
|
| 13 | };
|
| 14 | }
|
| 15 | exports.dynamodbStream = dynamodbStream;
|
| 16 | //# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoid3JhcHBlci5qcyIsInNvdXJjZVJvb3QiOiIiLCJzb3VyY2VzIjpbIi4uLy4uL3NyYy9keW5hbW9kYi1zdHJlYW0vd3JhcHBlci50cyJdLCJuYW1lcyI6W10sIm1hcHBpbmdzIjoiOzs7QUFDQSxxQ0FBeUQ7QUFDekQsc0NBQW9DO0FBQ3BDLDJDQUE2QztBQUU3QyxNQUFNLE9BQU8sR0FBRyxJQUFJLGdCQUFPLENBQUMsaUJBQWlCLENBQUMsQ0FBQztBQUUvQyxTQUFnQixjQUFjLENBQzVCLE1BQWtEO0lBRWxELE9BQU8sU0FBUyxPQUFPLENBQUMsS0FBMEIsRUFBRSxPQUFnQixFQUFFLFFBQWtCO1FBQ3RGLE1BQU0sRUFBRSxXQUFXLEVBQUUsV0FBVyxFQUFFLFFBQVEsRUFBRSxHQUFHLElBQUksNkJBQW9CLENBQUksS0FBSyxDQUFDLENBQUMsV0FBVyxFQUFFLENBQUM7UUFDaEcsT0FBTyxDQUFDLE1BQU0sQ0FBQyxFQUFFLFdBQVcsRUFBRSxXQUFXLEVBQUUsUUFBUSxFQUFFLENBQUMsQ0FBQztRQUN2RCxPQUFPLE1BQU0sQ0FBQyxFQUFFLEtBQUssRUFBRSxXQUFXLEVBQUUsV0FBVyxFQUFFLFFBQVEsRUFBRSxPQUFPLEVBQVAsbUJBQU8sRUFBRSxLQUFLLEVBQUwsaUJBQUssRUFBRSxDQUFDLENBQUM7SUFDL0UsQ0FBQyxDQUFDO0FBQ0osQ0FBQztBQVJELHdDQVFDIn0= |
| \ | No newline at end of file |