FM / features

/usr/local/lib/node_modules/pm2/node_modules/@pm2/io/build/main/features/

/usr/local/lib/node_modules/pm2/node_modules/@pm2/io/build/main/features

Name	Size	Mode	Actions
dependencies.d.ts	191	0644	edit dl rm
dependencies.js	1821	0644	edit dl rm
entrypoint.d.ts	310	0644	edit dl rm
entrypoint.js	1297	0644	edit dl rm
events.d.ts	227	0644	edit dl rm
events.js	1436	0644	edit dl rm
metrics.d.ts	939	0644	edit dl rm
metrics.js	2584	0644	edit dl rm
notify.d.ts	734	0644	edit dl rm
notify.js	8905	0644	edit dl rm
profiling.d.ts	459	0644	edit dl rm
profiling.js	2241	0644	edit dl rm

Edit: /usr/local/lib/node_modules/pm2/node_modules/@pm2/io/build/main/features/events.js (1436B)

"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.EventsFeature = void 0;
const serviceManager_1 = require("../serviceManager");
const Debug = require("debug");
class EventsFeature {
    constructor() {
        this.logger = Debug('axm:features:events');
    }
    init() {
        this.transport = serviceManager_1.ServiceManager.get('transport');
        this.logger('init');
    }
    emit(name, data) {
        if (typeof name !== 'string') {
            console.error('event name must be a string');
            return console.trace();
        }
        if (typeof data !== 'object') {
            console.error('event data must be an object');
            return console.trace();
        }
        if (data instanceof Array) {
            console.error(`event data cannot be an array`);
            return console.trace();
        }
        let inflightObj = {};
        try {
            inflightObj = JSON.parse(JSON.stringify(data));
        }
        catch (err) {
            return console.log('Failed to serialize the event data', err.message);
        }
        inflightObj.__name = name;
        if (this.transport === undefined) {
            return this.logger('Failed to send event as transporter isnt available');
        }
        this.transport.send('human:event', inflightObj);
    }
    destroy() {
        this.logger('destroy');
    }
}
exports.EventsFeature = EventsFeature;

"use strict"; Object.defineProperty(exports, "__esModule", { value: true }); exports.EventsFeature = void 0; const serviceManager_1 = require("../serviceManager"); const Debug = require("debug"); class EventsFeature { constructor() { this.logger = Debug('axm:features:events'); } init() { this.transport = serviceManager_1.ServiceManager.get('transport'); this.logger('init'); } emit(name, data) { if (typeof name !== 'string') { console.error('event name must be a string'); return console.trace(); } if (typeof data !== 'object') { console.error('event data must be an object'); return console.trace(); } if (data instanceof Array) { console.error(`event data cannot be an array`); return console.trace(); } let inflightObj = {}; try { inflightObj = JSON.parse(JSON.stringify(data)); } catch (err) { return console.log('Failed to serialize the event data', err.message); } inflightObj.__name = name; if (this.transport === undefined) { return this.logger('Failed to send event as transporter isnt available'); } this.transport.send('human:event', inflightObj); } destroy() { this.logger('destroy'); } } exports.EventsFeature = EventsFeature;