@pm2/agent - npm Package Compare versions

Comparing version 0.5.24 to 0.5.25

constants.js

@@ -56,2 +56,3 @@ /**
   PACKET_QUEUE_SIZE: 200,
+  PROXY: process.env.PM2_PROXY,
 
@@ -58,0 +59,0 @@ LOGS_BUFFER: 8,

package.json

 {
   "name": "@pm2/agent",
-  "version": "0.5.24",
+  "version": "0.5.25",
   "description": "PM2.io Agent Daemon",
@@ -20,2 +20,3 @@ "main": "index.js",
     "async": "^2.6.0",
+    "chalk": "^2.3.2",
     "eventemitter2": "^5.0.1",
@@ -27,5 +28,5 @@ "fclone": "^1.0.11",
     "pm2-axon-rpc": "^0.5.0",
-    "ws": "^5.1.0",
+    "proxy-agent": "^3.1.0",
     "semver": "^5.5.0",
-    "chalk": "^2.3.2"
+    "ws": "^5.1.0"
   },
@@ -35,4 +36,5 @@ "devDependencies": {
     "mocha": "^3.2",
-    "v8-coverage": "^1.0.4",
-    "nock": "^9.2.3"
+    "nock": "^9.2.3",
+    "simple-socks": "^1.0.2",
+    "v8-coverage": "^1.0.4"
   },
@@ -39,0 +41,0 @@ "author": "Keymetrics Team",

src/InteractorDaemon.js

@@ -370,3 +370,10 @@ 'use strict'
       // start workers
-      this._workerEndpoint = setInterval(this._verifyEndpoint.bind(this), 60000)
+      this._workerEndpoint = setInterval(this._verifyEndpoint.bind(this, (err, result) => {
+        if (err) return
+        // We need to exit agent if bucket is disabled (trialing)
+        if (result && typeof result === 'object' && result.error === true && result.active === false) {
+          log(`Error when connecting: ${result.msg}`)
+          return this.exit(new Error(`Error when connecting: ${result.msg}`))
+        }
+      }), 60000)
       // start interactors
@@ -373,0 +380,0 @@ this.watchDog = WatchDog

src/transporters/WebsocketTransport.js

 'use strict'
 
 const WebSocket = require('ws')
+const ProxyAgent = require('proxy-agent')
 const log = require('debug')('interactor:websocket')
@@ -57,3 +58,4 @@ const cst = require('../../constants.js')
         'User-Agent': `PM2 Agent v${pkg.version}`
-      }
+      },
+      agent: cst.PROXY ? new ProxyAgent(cst.PROXY) : undefined
     })
@@ -60,0 +62,0 @@

src/Utility.js

@@ -7,2 +7,4 @@ 'use strict'
 const url = require('url')
+const ProxyAgent = require('proxy-agent')
+const cst = require('../constants.js')
 
@@ -344,3 +346,4 @@ const interfaceType = {
       method: opts.method,
-      headers: opts.headers
+      headers: opts.headers,
+      agent: cst.PROXY ? new ProxyAgent(cst.PROXY) : undefined
     }
@@ -347,0 +350,0 @@

New alerts

Environment variable access

Supply chain risk

Package accesses environment variables, which may be a sign of credential stuffing or data theft.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

236810

increased by8.88%

Lines of code

3611

increased by0.36%

Worsened metrics

Dependency count

11

increased by10%

Dev dependency count

5

increased by25%

Number of low supply chain risk alerts

85

increased by1.19%

Dependency changes

• + Addedproxy-agent@^3.1.0

• + Addedagent-base@4.2.14.3.0(transitive)

• + Addedast-types@0.16.1(transitive)

• + Addedbytes@3.1.2(transitive)

• + Addedco@4.6.0(transitive)

• + Addedcore-util-is@1.0.3(transitive)

• + Addeddata-uri-to-buffer@1.2.0(transitive)

• + Addeddebug@2.6.93.1.04.4.0(transitive)

• + Addeddeep-is@0.1.4(transitive)

• + Addeddegenerator@1.0.4(transitive)

• + Addeddepd@2.0.0(transitive)

• + Addedes6-promise@4.2.8(transitive)

• + Addedes6-promisify@5.0.0(transitive)

• + Addedescodegen@1.14.3(transitive)

• + Addedesprima@3.1.34.0.1(transitive)

• + Addedestraverse@4.3.0(transitive)

• + Addedesutils@2.0.3(transitive)

• + Addedextend@3.0.2(transitive)

• + Addedfast-levenshtein@2.0.6(transitive)

• + Addedfile-uri-to-path@1.0.0(transitive)

• + Addedftp@0.3.10(transitive)

• + Addedget-uri@2.0.4(transitive)

• + Addedhttp-errors@2.0.0(transitive)

• + Addedhttp-proxy-agent@2.1.0(transitive)

• + Addedhttps-proxy-agent@3.0.1(transitive)

• + Addediconv-lite@0.4.24(transitive)

• + Addedinherits@2.0.4(transitive)

• + Addedip@1.1.51.1.9(transitive)

• + Addedisarray@0.0.11.0.0(transitive)

• + Addedlevn@0.3.0(transitive)

• + Addedlru-cache@5.1.1(transitive)

• + Addedms@2.0.0(transitive)

• + Addednetmask@1.0.6(transitive)

• + Addedoptionator@0.8.3(transitive)

• + Addedpac-proxy-agent@3.0.1(transitive)

• + Addedpac-resolver@3.0.0(transitive)

• + Addedprelude-ls@1.1.2(transitive)

• + Addedprocess-nextick-args@2.0.1(transitive)

• + Addedproxy-agent@3.1.1(transitive)

• + Addedproxy-from-env@1.1.0(transitive)

• + Addedraw-body@2.5.2(transitive)

• + Addedreadable-stream@1.1.142.3.8(transitive)

• + Addedsafe-buffer@5.1.2(transitive)

• + Addedsafer-buffer@2.1.2(transitive)

• + Addedsetprototypeof@1.2.0(transitive)

• + Addedsmart-buffer@4.2.0(transitive)

• + Addedsocks@2.3.3(transitive)

• + Addedsocks-proxy-agent@4.0.2(transitive)

• + Addedsource-map@0.6.1(transitive)

• + Addedstatuses@2.0.1(transitive)

• + Addedstring_decoder@0.10.311.1.1(transitive)

• + Addedthunkify@2.1.2(transitive)

• + Addedtoidentifier@1.0.1(transitive)

• + Addedtslib@2.8.1(transitive)

• + Addedtype-check@0.3.2(transitive)

• + Addedunpipe@1.0.0(transitive)

• + Addedutil-deprecate@1.0.2(transitive)

• + Addedword-wrap@1.2.5(transitive)

• + Addedxregexp@2.0.0(transitive)

• + Addedyallist@3.1.1(transitive)