| "use strict"; | ||
| Object.defineProperty(exports, "__esModule", { value: true }); | ||
| const IPCTransport_1 = require("../transports/IPCTransport"); | ||
| const WebsocketTransport_1 = require("../transports/WebsocketTransport"); | ||
| class TransportConfig { | ||
@@ -9,18 +8,7 @@ } | ||
| function createTransport(name, config) { | ||
| switch (name) { | ||
| case 'ipc': { | ||
| const transport = new IPCTransport_1.IPCTransport(); | ||
| transport.init(config); | ||
| return transport; | ||
| } | ||
| case 'websocket': { | ||
| const transport = new WebsocketTransport_1.WebsocketTransport(); | ||
| transport.init(config); | ||
| return transport; | ||
| } | ||
| } | ||
| console.error(`Failed to find transport implementation: ${name}`); | ||
| return process.exit(1); | ||
| const transport = new IPCTransport_1.IPCTransport(); | ||
| transport.init(config); | ||
| return transport; | ||
| } | ||
| exports.createTransport = createTransport; | ||
| //# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoidHJhbnNwb3J0LmpzIiwic291cmNlUm9vdCI6IiIsInNvdXJjZXMiOlsiLi4vLi4vLi4vc3JjL3NlcnZpY2VzL3RyYW5zcG9ydC50cyJdLCJuYW1lcyI6W10sIm1hcHBpbmdzIjoiOztBQUdBLDZEQUF5RDtBQUN6RCx5RUFBcUU7QUFHckUsTUFBYSxlQUFlO0NBMEMzQjtBQTFDRCwwQ0EwQ0M7QUFnQ0QsU0FBZ0IsZUFBZSxDQUFFLElBQVksRUFBRSxNQUF1QjtJQUNwRSxRQUFRLElBQUksRUFBRTtRQUNaLEtBQUssS0FBSyxDQUFDLENBQUM7WUFDVixNQUFNLFNBQVMsR0FBRyxJQUFJLDJCQUFZLEVBQUUsQ0FBQTtZQUNwQyxTQUFTLENBQUMsSUFBSSxDQUFDLE1BQU0sQ0FBQyxDQUFBO1lBQ3RCLE9BQU8sU0FBUyxDQUFBO1NBQ2pCO1FBQ0QsS0FBSyxXQUFXLENBQUMsQ0FBQztZQUNoQixNQUFNLFNBQVMsR0FBRyxJQUFJLHVDQUFrQixFQUFFLENBQUE7WUFDMUMsU0FBUyxDQUFDLElBQUksQ0FBQyxNQUFNLENBQUMsQ0FBQTtZQUN0QixPQUFPLFNBQVMsQ0FBQTtTQUNqQjtLQUNGO0lBQ0QsT0FBTyxDQUFDLEtBQUssQ0FBQyw0Q0FBNEMsSUFBSSxFQUFFLENBQUMsQ0FBQTtJQUNqRSxPQUFPLE9BQU8sQ0FBQyxJQUFJLENBQUMsQ0FBQyxDQUFDLENBQUE7QUFDeEIsQ0FBQztBQWZELDBDQWVDIn0= | ||
| //# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoidHJhbnNwb3J0LmpzIiwic291cmNlUm9vdCI6IiIsInNvdXJjZXMiOlsiLi4vLi4vLi4vc3JjL3NlcnZpY2VzL3RyYW5zcG9ydC50cyJdLCJuYW1lcyI6W10sIm1hcHBpbmdzIjoiOztBQUdBLDZEQUF5RDtBQUl6RCxNQUFhLGVBQWU7Q0EwQzNCO0FBMUNELDBDQTBDQztBQWdDRCxTQUFnQixlQUFlLENBQUUsSUFBWSxFQUFFLE1BQXVCO0lBQ3BFLE1BQU0sU0FBUyxHQUFHLElBQUksMkJBQVksRUFBRSxDQUFBO0lBQ3BDLFNBQVMsQ0FBQyxJQUFJLENBQUMsTUFBTSxDQUFDLENBQUE7SUFDdEIsT0FBTyxTQUFTLENBQUE7QUFlbEIsQ0FBQztBQWxCRCwwQ0FrQkMifQ== |
@@ -1,102 +0,1 @@ | ||
| "use strict"; | ||
| Object.defineProperty(exports, "__esModule", { value: true }); | ||
| const debug_1 = require("debug"); | ||
| const eventemitter2_1 = require("eventemitter2"); | ||
| class SerializedAction { | ||
| } | ||
| class ProcessMetadata { | ||
| } | ||
| exports.ProcessMetadata = ProcessMetadata; | ||
| class WebsocketTransport extends eventemitter2_1.EventEmitter2 { | ||
| constructor() { | ||
| super(...arguments); | ||
| this.initiated = false; | ||
| this.logger = debug_1.default('axm:transport:websocket'); | ||
| } | ||
| init(config) { | ||
| if (this.initiated === true) { | ||
| console.error(`Trying to re-init the transport, please avoid`); | ||
| return this; | ||
| } | ||
| this.initiated = true; | ||
| const AgentNode = require('@pm2/agent-node'); | ||
| this.logger('Init new transport service'); | ||
| this.config = config; | ||
| this.process = { | ||
| axm_actions: [], | ||
| axm_options: {}, | ||
| axm_monitor: {} | ||
| }; | ||
| this.agent = new AgentNode(this.config, this.process); | ||
| if (this.agent instanceof Error) { | ||
| throw this.agent; | ||
| } | ||
| this.agent.sendLogs = config.sendLogs || false; | ||
| this.agent.start(); | ||
| this.agent.transport.on('**', (data) => { | ||
| this.logger(`Received reverse message from websocket transport`); | ||
| this.emit('data', data); | ||
| }); | ||
| this.logger('Agent launched'); | ||
| return this; | ||
| } | ||
| setMetrics(metrics) { | ||
| return this.process.axm_monitor = metrics.reduce((object, metric) => { | ||
| if (typeof metric.name !== 'string') | ||
| return object; | ||
| object[metric.name] = { | ||
| historic: metric.historic, | ||
| unit: metric.unit, | ||
| type: metric.id, | ||
| value: metric.value | ||
| }; | ||
| return object; | ||
| }, {}); | ||
| } | ||
| addAction(action) { | ||
| this.logger(`Add action: ${action.name}:${action.type}`); | ||
| const serializedAction = { | ||
| action_name: action.name, | ||
| action_type: action.type, | ||
| arity: action.arity, | ||
| opts: action.opts | ||
| }; | ||
| this.process.axm_actions.push(serializedAction); | ||
| } | ||
| setOptions(options) { | ||
| this.logger(`Set options: [${Object.keys(options).join(',')}]`); | ||
| return this.process.axm_options = Object.assign(this.process.axm_options, options); | ||
| } | ||
| getFormattedPayload(channel, payload) { | ||
| switch (channel) { | ||
| case 'axm:reply': | ||
| return { data: payload }; | ||
| case 'process:exception': | ||
| return { data: payload }; | ||
| case 'human:event': { | ||
| const name = payload.__name; | ||
| payload.__name = undefined; | ||
| return { name, data: payload }; | ||
| } | ||
| } | ||
| return payload; | ||
| } | ||
| send(channel, payload) { | ||
| return this.agent.send(channel, this.getFormattedPayload(channel, payload)) ? 0 : -1; | ||
| } | ||
| destroy() { | ||
| this.agent.transport.disconnect(); | ||
| this.logger('destroy'); | ||
| } | ||
| removeListener() { | ||
| return this.agent.transport.removeListener.apply(this, arguments); | ||
| } | ||
| removeAllListeners() { | ||
| return this.agent.transport.removeAllListeners.apply(this, arguments); | ||
| } | ||
| on() { | ||
| return this.agent.transport.on.apply(this, arguments); | ||
| } | ||
| } | ||
| exports.WebsocketTransport = WebsocketTransport; | ||
| //# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoiV2Vic29ja2V0VHJhbnNwb3J0LmpzIiwic291cmNlUm9vdCI6IiIsInNvdXJjZXMiOlsiLi4vLi4vLi4vc3JjL3RyYW5zcG9ydHMvV2Vic29ja2V0VHJhbnNwb3J0LnRzIl0sIm5hbWVzIjpbXSwibWFwcGluZ3MiOiI7O0FBQ0EsaUNBQXlCO0FBR3pCLGlEQUE2QztBQUU3QyxNQUFNLGdCQUFnQjtDQUtyQjtBQUVELE1BQWEsZUFBZTtDQU8zQjtBQVBELDBDQU9DO0FBRUQsTUFBYSxrQkFBbUIsU0FBUSw2QkFBYTtJQUFyRDs7UUFLVSxjQUFTLEdBQVksS0FBSyxDQUFBO1FBQzFCLFdBQU0sR0FBYSxlQUFLLENBQUMseUJBQXlCLENBQUMsQ0FBQTtJQStGN0QsQ0FBQztJQTdGQyxJQUFJLENBQUUsTUFBdUI7UUFDM0IsSUFBSSxJQUFJLENBQUMsU0FBUyxLQUFLLElBQUksRUFBRTtZQUMzQixPQUFPLENBQUMsS0FBSyxDQUFDLCtDQUErQyxDQUFDLENBQUE7WUFDOUQsT0FBTyxJQUFJLENBQUE7U0FDWjtRQUNELElBQUksQ0FBQyxTQUFTLEdBQUcsSUFBSSxDQUFBO1FBQ3JCLE1BQU0sU0FBUyxHQUFHLE9BQU8sQ0FBQyxpQkFBaUIsQ0FBQyxDQUFBO1FBQzVDLElBQUksQ0FBQyxNQUFNLENBQUMsNEJBQTRCLENBQUMsQ0FBQTtRQUN6QyxJQUFJLENBQUMsTUFBTSxHQUFHLE1BQU0sQ0FBQTtRQUNwQixJQUFJLENBQUMsT0FBTyxHQUFHO1lBQ2IsV0FBVyxFQUFFLEVBQUU7WUFDZixXQUFXLEVBQUUsRUFBRTtZQUNmLFdBQVcsRUFBRSxFQUFFO1NBQ2hCLENBQUE7UUFDRCxJQUFJLENBQUMsS0FBSyxHQUFHLElBQUksU0FBUyxDQUFDLElBQUksQ0FBQyxNQUFNLEVBQUUsSUFBSSxDQUFDLE9BQU8sQ0FBQyxDQUFBO1FBQ3JELElBQUksSUFBSSxDQUFDLEtBQUssWUFBWSxLQUFLLEVBQUU7WUFDL0IsTUFBTSxJQUFJLENBQUMsS0FBSyxDQUFBO1NBQ2pCO1FBQ0QsSUFBSSxDQUFDLEtBQUssQ0FBQyxRQUFRLEdBQUcsTUFBTSxDQUFDLFFBQVEsSUFBSSxLQUFLLENBQUE7UUFDOUMsSUFBSSxDQUFDLEtBQUssQ0FBQyxLQUFLLEVBQUUsQ0FBQTtRQUNsQixJQUFJLENBQUMsS0FBSyxDQUFDLFNBQVMsQ0FBQyxFQUFFLENBQUMsSUFBSSxFQUFFLENBQUMsSUFBSSxFQUFFLEVBQUU7WUFDckMsSUFBSSxDQUFDLE1BQU0sQ0FBQyxtREFBbUQsQ0FBQyxDQUFBO1lBQ2hFLElBQUksQ0FBQyxJQUFJLENBQUMsTUFBTSxFQUFFLElBQUksQ0FBQyxDQUFBO1FBQ3pCLENBQUMsQ0FBQyxDQUFBO1FBQ0YsSUFBSSxDQUFDLE1BQU0sQ0FBQyxnQkFBZ0IsQ0FBQyxDQUFBO1FBQzdCLE9BQU8sSUFBSSxDQUFBO0lBQ2IsQ0FBQztJQUVELFVBQVUsQ0FBRSxPQUF5QjtRQUNuQyxPQUFPLElBQUksQ0FBQyxPQUFPLENBQUMsV0FBVyxHQUFHLE9BQU8sQ0FBQyxNQUFNLENBQUMsQ0FBQyxNQUFNLEVBQUUsTUFBc0IsRUFBRSxFQUFFO1lBQ2xGLElBQUksT0FBTyxNQUFNLENBQUMsSUFBSSxLQUFLLFFBQVE7Z0JBQUUsT0FBTyxNQUFNLENBQUE7WUFDbEQsTUFBTSxDQUFDLE1BQU0sQ0FBQyxJQUFJLENBQUMsR0FBRztnQkFDcEIsUUFBUSxFQUFFLE1BQU0sQ0FBQyxRQUFRO2dCQUN6QixJQUFJLEVBQUUsTUFBTSxDQUFDLElBQUk7Z0JBQ2pCLElBQUksRUFBRSxNQUFNLENBQUMsRUFBRTtnQkFDZixLQUFLLEVBQUUsTUFBTSxDQUFDLEtBQUs7YUFDcEIsQ0FBQTtZQUNELE9BQU8sTUFBTSxDQUFBO1FBQ2YsQ0FBQyxFQUFFLEVBQUUsQ0FBQyxDQUFBO0lBQ1IsQ0FBQztJQUVELFNBQVMsQ0FBRSxNQUFjO1FBQ3ZCLElBQUksQ0FBQyxNQUFNLENBQUMsZUFBZSxNQUFNLENBQUMsSUFBSSxJQUFJLE1BQU0sQ0FBQyxJQUFJLEVBQUUsQ0FBQyxDQUFBO1FBQ3hELE1BQU0sZ0JBQWdCLEdBQXFCO1lBQ3pDLFdBQVcsRUFBRSxNQUFNLENBQUMsSUFBSTtZQUN4QixXQUFXLEVBQUUsTUFBTSxDQUFDLElBQUk7WUFDeEIsS0FBSyxFQUFFLE1BQU0sQ0FBQyxLQUFLO1lBQ25CLElBQUksRUFBRSxNQUFNLENBQUMsSUFBSTtTQUNsQixDQUFBO1FBQ0QsSUFBSSxDQUFDLE9BQU8sQ0FBQyxXQUFXLENBQUMsSUFBSSxDQUFDLGdCQUFnQixDQUFDLENBQUE7SUFDakQsQ0FBQztJQUVELFVBQVUsQ0FBRSxPQUFPO1FBQ2pCLElBQUksQ0FBQyxNQUFNLENBQUMsaUJBQWlCLE1BQU0sQ0FBQyxJQUFJLENBQUMsT0FBTyxDQUFDLENBQUMsSUFBSSxDQUFDLEdBQUcsQ0FBQyxHQUFHLENBQUMsQ0FBQTtRQUMvRCxPQUFPLElBQUksQ0FBQyxPQUFPLENBQUMsV0FBVyxHQUFHLE1BQU0sQ0FBQyxNQUFNLENBQUMsSUFBSSxDQUFDLE9BQU8sQ0FBQyxXQUFXLEVBQUUsT0FBTyxDQUFDLENBQUE7SUFDcEYsQ0FBQztJQUVPLG1CQUFtQixDQUFFLE9BQWUsRUFBRSxPQUFZO1FBRXhELFFBQVEsT0FBTyxFQUFFO1lBQ2YsS0FBSyxXQUFXO2dCQUNkLE9BQU8sRUFBRSxJQUFJLEVBQUUsT0FBTyxFQUFFLENBQUE7WUFDMUIsS0FBSyxtQkFBbUI7Z0JBQ3RCLE9BQU8sRUFBRSxJQUFJLEVBQUUsT0FBTyxFQUFFLENBQUE7WUFDMUIsS0FBSyxhQUFhLENBQUMsQ0FBQztnQkFDbEIsTUFBTSxJQUFJLEdBQUcsT0FBTyxDQUFDLE1BQU0sQ0FBQTtnQkFDM0IsT0FBTyxDQUFDLE1BQU0sR0FBRyxTQUFTLENBQUE7Z0JBQzFCLE9BQU8sRUFBRSxJQUFJLEVBQUUsSUFBSSxFQUFFLE9BQU8sRUFBRSxDQUFBO2FBQy9CO1NBQ0Y7UUFDRCxPQUFPLE9BQU8sQ0FBQTtJQUNoQixDQUFDO0lBRUQsSUFBSSxDQUFFLE9BQWUsRUFBRSxPQUFlO1FBQ3BDLE9BQU8sSUFBSSxDQUFDLEtBQUssQ0FBQyxJQUFJLENBQUMsT0FBTyxFQUFFLElBQUksQ0FBQyxtQkFBbUIsQ0FBQyxPQUFPLEVBQUUsT0FBTyxDQUFDLENBQUMsQ0FBQyxDQUFDLENBQUMsQ0FBQyxDQUFDLENBQUMsQ0FBQyxDQUFDLENBQUMsQ0FBQTtJQUN0RixDQUFDO0lBRUQsT0FBTztRQUNMLElBQUksQ0FBQyxLQUFLLENBQUMsU0FBUyxDQUFDLFVBQVUsRUFBRSxDQUFBO1FBQ2pDLElBQUksQ0FBQyxNQUFNLENBQUMsU0FBUyxDQUFDLENBQUE7SUFDeEIsQ0FBQztJQUVELGNBQWM7UUFDWixPQUFPLElBQUksQ0FBQyxLQUFLLENBQUMsU0FBUyxDQUFDLGNBQWMsQ0FBQyxLQUFLLENBQUMsSUFBSSxFQUFFLFNBQVMsQ0FBQyxDQUFBO0lBQ25FLENBQUM7SUFFRCxrQkFBa0I7UUFDaEIsT0FBTyxJQUFJLENBQUMsS0FBSyxDQUFDLFNBQVMsQ0FBQyxrQkFBa0IsQ0FBQyxLQUFLLENBQUMsSUFBSSxFQUFFLFNBQVMsQ0FBQyxDQUFBO0lBQ3ZFLENBQUM7SUFFRCxFQUFFO1FBQ0EsT0FBTyxJQUFJLENBQUMsS0FBSyxDQUFDLFNBQVMsQ0FBQyxFQUFFLENBQUMsS0FBSyxDQUFDLElBQUksRUFBRSxTQUFTLENBQUMsQ0FBQTtJQUN2RCxDQUFDO0NBQ0Y7QUFyR0QsZ0RBcUdDIn0= | ||
| //# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoiV2Vic29ja2V0VHJhbnNwb3J0LmpzIiwic291cmNlUm9vdCI6IiIsInNvdXJjZXMiOlsiLi4vLi4vLi4vc3JjL3RyYW5zcG9ydHMvV2Vic29ja2V0VHJhbnNwb3J0LnRzIl0sIm5hbWVzIjpbXSwibWFwcGluZ3MiOiIifQ== |
+11
-12
| { | ||
| "name": "@pm2/io", | ||
| "version": "4.3.5", | ||
| "version": "5.0.0", | ||
| "description": "PM2.io NodeJS APM", | ||
@@ -43,2 +43,3 @@ "main": "build/main/index.js", | ||
| "devDependencies": { | ||
| "@pm2/node-runtime-stats": "^0.3.2", | ||
| "@types/chai": "4.1.4", | ||
@@ -52,5 +53,13 @@ "@types/express": "~4.16.1", | ||
| "chai": "4.1.2", | ||
| "express": "^4.17.1", | ||
| "ioredis": "^4.16.3", | ||
| "koa": "^2.11.0", | ||
| "mocha": "~7.1.0", | ||
| "mongodb-core": "^3.2.7", | ||
| "mysql": "~2.18.1", | ||
| "mysql2": "~2.1.0", | ||
| "nock": "~10.0.6", | ||
| "nyc": "~13.1.0", | ||
| "pg": "^7.18.2", | ||
| "redis": "^3.0.2", | ||
| "source-map-support": "~0.5.9", | ||
@@ -61,11 +70,2 @@ "ts-node": "~7.0.1", | ||
| "typescript": "~3.2.2", | ||
| "@pm2/node-runtime-stats": "^0.3.2", | ||
| "express": "^4.17.1", | ||
| "ioredis": "^4.16.3", | ||
| "koa": "^2.11.0", | ||
| "mongodb-core": "^3.2.7", | ||
| "mysql": "^2.18.1", | ||
| "mysql2": "^2.1.0", | ||
| "pg": "^7.18.2", | ||
| "redis": "^3.0.2", | ||
| "vue": "^2.6.11", | ||
@@ -91,5 +91,4 @@ "vue-server-renderer": "^2.6.11" | ||
| "@opencensus/propagation-b3": "0.0.8", | ||
| "@pm2/agent-node": "^1.1.10", | ||
| "async": "~2.6.1", | ||
| "debug": "4.1.1", | ||
| "debug": "~4.3.1", | ||
| "eventemitter2": "^6.3.1", | ||
@@ -96,0 +95,0 @@ "require-in-the-middle": "^5.0.0", |
+2
-2
@@ -17,4 +17,4 @@ | ||
| $MOCHA ./test/entrypoint.spec.ts | ||
| $MOCHA ./test/standalone/tracing.spec.ts | ||
| $MOCHA ./test/standalone/events.spec.ts | ||
| # $MOCHA ./test/standalone/tracing.spec.ts | ||
| # $MOCHA ./test/standalone/events.spec.ts | ||
| $MOCHA ./test/features/events.spec.ts | ||
@@ -21,0 +21,0 @@ $MOCHA ./test/features/tracing.spec.ts |
Network access
Supply chain riskThis module accesses the network.
Found 5 instances in 1 package
Debug access
Supply chain riskUses debug, reflection and dynamic code execution features.
Found 2 instances in 1 package
Dynamic require
Supply chain riskDynamic require can indicate the package is performing dangerous or unsafe dynamic code execution.
Found 1 instance in 1 package
Environment variable access
Supply chain riskPackage accesses environment variables, which may be a sign of credential stuffing or data theft.
Found 12 instances in 1 package
Filesystem access
Supply chain riskAccesses the file system, and could potentially read sensitive data.
Found 1 instance in 1 package
Long strings
Supply chain riskContains long string literals, which may be a sign of obfuscated or packed code.
Found 1 instance in 1 package
Minified code
QualityThis package contains minified code. This may be harmless in some cases where minified code is included in packaged libraries, however packages on npm should not minify code.
Found 1 instance in 1 package
Network access
Supply chain riskThis module accesses the network.
Found 5 instances in 1 package
Debug access
Supply chain riskUses debug, reflection and dynamic code execution features.
Found 2 instances in 1 package
Dynamic require
Supply chain riskDynamic require can indicate the package is performing dangerous or unsafe dynamic code execution.
Found 1 instance in 1 package
Environment variable access
Supply chain riskPackage accesses environment variables, which may be a sign of credential stuffing or data theft.
Found 12 instances in 1 package
Filesystem access
Supply chain riskAccesses the file system, and could potentially read sensitive data.
Found 1 instance in 1 package
Long strings
Supply chain riskContains long string literals, which may be a sign of obfuscated or packed code.
Found 1 instance in 1 package
10
-9.09%559662
-1.67%6696
-2.18%3
50%+ Added
- Removed
- Removed
- Removed
- Removed
- Removed
- Removed
- Removed
- Removed
- Removed
- Removed
- Removed
- Removed
- Removed
- Removed
- Removed
- Removed
- Removed
- Removed
- Removed
- Removed
- Removed
- Removed
- Removed
- Removed
- Removed
- Removed
- Removed
- Removed
- Removed
- Removed
- Removed
- Removed
- Removed
- Removed
- Removed
- Removed
- Removed
- Removed
- Removed
- Removed
- Removed
- Removed
- Removed
- Removed
- Removed
- Removed
- Removed
- Removed
- Removed
- Removed
- Removed
- Removed
- Removed
- Removed
- Removed
- Removed
- Removed
- Removed
- Removed
- Removed
- Removed
- Removed
- Removed
- Removed
Updated