@banzaicloud/service-tools/dist/catch-errors.js

"use strict";
var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, generator) {
    function adopt(value) { return value instanceof P ? value : new P(function (resolve) { resolve(value); }); }
    return new (P || (P = Promise))(function (resolve, reject) {
        function fulfilled(value) { try { step(generator.next(value)); } catch (e) { reject(e); } }
        function rejected(value) { try { step(generator["throw"](value)); } catch (e) { reject(e); } }
        function step(result) { result.done ? resolve(result.value) : adopt(result.value).then(fulfilled, rejected); }
        step((generator = generator.apply(thisArg, _arguments || [])).next());
    });
};
Object.defineProperty(exports, "__esModule", { value: true });
const logger_1 = require("./logger");
function catchErrors(closeHandlers = [], { exitOnUncaughtPromiseException = true, logger = logger_1.default.fatal.bind(logger_1.default), timeout = 30, } = {}) {
    // it is not safe to resume normal operation after 'uncaughtException'.
    // read more: https://nodejs.org/api/process.html#process_event_uncaughtexception
    const uncaughtExceptionHandler = (err) => __awaiter(this, void 0, void 0, function* () {
        logger(err, 'uncaught exception');
        // shut down anyway after `timeout` seconds
        if (timeout) {
            setTimeout(() => {
                logger('could not finish in time, forcefully exiting');
                process.exit(1);
            }, timeout * 1000).unref();
        }
        for (const handler of closeHandlers) {
            try {
                yield Promise.resolve(handler());
            }
            catch (err) {
                logger(err, 'failed to close resource');
            }
        }
        process.exit(1);
    });
    process.on('uncaughtException', uncaughtExceptionHandler);
    // a Promise is rejected and no error handler is attached.
    // read more: https://nodejs.org/api/process.html#process_event_unhandledrejection
    const unhandledRejectionHandler = (reason = {}, promise) => __awaiter(this, void 0, void 0, function* () {
        logger(reason, 'unhandled promise rejection');
        // shut down anyway after `timeout` seconds
        if (timeout) {
            setTimeout(() => {
                logger('could not finish in time, forcefully exiting');
                process.exit(1);
            }, timeout * 1000).unref();
        }
        for (const handler of closeHandlers) {
            try {
                yield Promise.resolve(handler());
            }
            catch (err) {
                logger(err, 'failed to close resource');
            }
        }
        if (exitOnUncaughtPromiseException) {
            process.exit(1);
        }
    });
    process.on('unhandledRejection', unhandledRejectionHandler);
    return () => {
        process.off('uncaughtException', uncaughtExceptionHandler);
        process.off('unhandledRejection', unhandledRejectionHandler);
    };
}
exports.default = catchErrors;
//# sourceMappingURL=catch-errors.js.map