@pm2/io - npm Package Compare versions

Comparing version 4.3.5 to 5.0.0

build/main/services/transport.js

 "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==

build/main/transports/WebsocketTransport.js

@@ -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==

package.json

 {
   "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",

No alert changes

Improved metrics

Dependency count

10

-9.09%

Worsened metrics

Total package byte prevSize

559662

-1.67%

Lines of code

6696

-2.18%

Dependency changes

• + Added

  debug@4.3.7
  (transitive)

• - Removed

  @pm2/agent-node@^1.1.10

• - Removed

  @pm2/agent-node@1.1.10
  (transitive)

• - Removed

  agent-base@4.2.14.3.0
  (transitive)

• - Removed

  ast-types@0.16.1
  (transitive)

• - Removed

  async-limiter@1.0.1
  (transitive)

• - Removed

  bytes@3.1.2
  (transitive)

• - Removed

  co@4.6.0
  (transitive)

• - Removed

  core-util-is@1.0.3
  (transitive)

• - Removed

  data-uri-to-buffer@1.2.0
  (transitive)

• - Removed

  debug@2.6.93.1.03.2.74.1.1
  (transitive)

• - Removed

  deep-is@0.1.4
  (transitive)

• - Removed

  degenerator@1.0.4
  (transitive)

• - Removed

  depd@2.0.0
  (transitive)

• - Removed

  es6-promise@4.2.8
  (transitive)

• - Removed

  es6-promisify@5.0.0
  (transitive)

• - Removed

  escodegen@1.14.3
  (transitive)

• - Removed

  esprima@3.1.34.0.1
  (transitive)

• - Removed

  estraverse@4.3.0
  (transitive)

• - Removed

  esutils@2.0.3
  (transitive)

• - Removed

  eventemitter2@5.0.1
  (transitive)

• - Removed

  extend@3.0.2
  (transitive)

• - Removed

  fast-levenshtein@2.0.6
  (transitive)

• - Removed

  file-uri-to-path@1.0.0
  (transitive)

• - Removed

  ftp@0.3.10
  (transitive)

• - Removed

  get-uri@2.0.4
  (transitive)

• - Removed

  http-errors@2.0.0
  (transitive)

• - Removed

  http-proxy-agent@2.1.0
  (transitive)

• - Removed

  https-proxy-agent@3.0.1
  (transitive)

• - Removed

  iconv-lite@0.4.24
  (transitive)

• - Removed

  inherits@2.0.4
  (transitive)

• - Removed

  ip@1.1.51.1.9
  (transitive)

• - Removed

  isarray@0.0.11.0.0
  (transitive)

• - Removed

  levn@0.3.0
  (transitive)

• - Removed

  lru-cache@5.1.1
  (transitive)

• - Removed

  ms@2.0.0
  (transitive)

• - Removed

  netmask@1.0.6
  (transitive)

• - Removed

  optionator@0.8.3
  (transitive)

• - Removed

  pac-proxy-agent@3.0.1
  (transitive)

• - Removed

  pac-resolver@3.0.0
  (transitive)

• - Removed

  prelude-ls@1.1.2
  (transitive)

• - Removed

  process-nextick-args@2.0.1
  (transitive)

• - Removed

  proxy-agent@3.1.1
  (transitive)

• - Removed

  proxy-from-env@1.1.0
  (transitive)

• - Removed

  raw-body@2.5.2
  (transitive)

• - Removed

  readable-stream@1.1.142.3.8
  (transitive)

• - Removed

  safe-buffer@5.1.2
  (transitive)

• - Removed

  safer-buffer@2.1.2
  (transitive)

• - Removed

  setprototypeof@1.2.0
  (transitive)

• - Removed

  smart-buffer@4.2.0
  (transitive)

• - Removed

  socks@2.3.3
  (transitive)

• - Removed

  socks-proxy-agent@4.0.2
  (transitive)

• - Removed

  source-map@0.6.1
  (transitive)

• - Removed

  statuses@2.0.1
  (transitive)

• - Removed

  string_decoder@0.10.311.1.1
  (transitive)

• - Removed

  thunkify@2.1.2
  (transitive)

• - Removed

  toidentifier@1.0.1
  (transitive)

• - Removed

  tslib@2.8.1
  (transitive)

• - Removed

  type-check@0.3.2
  (transitive)

• - Removed

  unpipe@1.0.0
  (transitive)

• - Removed

  util-deprecate@1.0.2
  (transitive)

• - Removed

  word-wrap@1.2.5
  (transitive)

• - Removed

  ws@6.2.3
  (transitive)

• - Removed

  xregexp@2.0.0
  (transitive)

• - Removed

  yallist@3.1.1
  (transitive)

• Updated

  debug@~4.3.1