index.js

"use strict";
function log(event, executionContent) {
    var date1_ms = executionContent.startedAt.getTime();
    var date2_ms = executionContent.finishedAt.getTime();
    var executionTime = Number.isFinite(date2_ms - date1_ms)
        ? date2_ms - date1_ms
        : 0;
    var logExt = {
        event: event,
        response: {
            statusCode: executionContent.statusCode,
            body: executionContent.resBody,
        },
        executionTime: executionTime,
    };
    console.log("firetail:log-ext:" +
        Buffer.from(JSON.stringify(logExt)).toString("base64"));
}
function wrap(next) {
    return function (event, context) {
        var startedAt = new Date();
        var observations = [];
        var workInProgress;
        if (next.constructor.name === "Promise" ||
            next.constructor.name === "AsyncFunction") {
            workInProgress = next(event, context, function () { });
        }
        else if (typeof next === "function") {
            workInProgress = Promise.resolve(next(event, context, function () { }));
        }
        else {
            workInProgress = Promise.resolve(next);
        }
        return workInProgress.then(function (result) {
            var body = result.body, statusCode = result.statusCode;
            var finishedAt = new Date();
            log(event, {
                statusCode: statusCode || 200,
                resBody: body,
                startedAt: startedAt,
                finishedAt: finishedAt,
            });
            return result;
        });
    };
}
module.exports = wrap;
//# sourceMappingURL=index.js.map