Method _parseProcess

src/Pm2Module.js:83–128

* Converts a PM2 process object to an object for WebhookServer * route. * * Example 1: * - input: { pm2_env: { env_hook: { name: 'api', type: 'bitbucket' } } } * - output: { name: 'api', type: 'bitbucket' } * Example 2: * - input: { pm2_env: { env_hook: { type: 'bi

(app)

     * @private
     */
    static _parseProcess(app) {
        // Check data
        if (!app || !app.pm2_env) {
            return null;
        }
        let config = app.pm2_env.env_hook;
        if (!config) {
            log(`No options found for "${app.name}" route`);
            return null;
        }
        if (config === true) {
            config = {};
        }

        // Config to WebhookServer route
        let self = this;
        let name = app.name || 'unknown';
        let cwd = config.cwd || app.pm_cwd || app.pm2_env.cwd || app.pm2_env.pm_cwd;
        let commandOptions = Object.assign({}, { cwd }, config.commandOptions || {});
        let route = {
            name,
            type: config.type,
            secret: config.secret,
            method(payload) {
                log(`Parsed payload: ${JSON.stringify(payload)}`);
                try {
                    if (config.command) {
                        log(`Running command: ${config.command}`);
                        self._runCommand(config.command, commandOptions)
                            .catch(e => onError(name, e));
                    }
                } catch (e) {
                    onError(name, e);
                }
            }
        };
        route = cleanObj(route);

        return route;

        function onError(routeName, e) {
            let err = e.message || e;
            log(`Error on "${name}" route: ${err}`, 2);
            throw e;
        }
    }

    /**
     * Runs a line command.