Use http-proxy-agent and https-proxy-agent instead of hpagent

lib/remote-model.js

@@ -122,28 +122,36 @@ class RemoteModel extends LocalModel {
     proxy(proxy = this.options.proxy, url) {
         if (!proxy || !url) return;
 
-        if (typeof proxy === 'string') proxy = { proxy };
+        if (typeof proxy === 'string') proxy = { uri: proxy };
+
+        const proxyUrl = new URL(proxy.uri);
+
+        const getAuth = u =>
+            u.username && u.password ? decodeURIComponent(`${u.username}:${u.password}`) :
+                u.username ? decodeURIComponent(u.username) : null;
+
+        const getPath = u => u.pathname + u.search + u.hash;
+
+        const options = Object.assign({
+            host: proxyUrl.hostname,
+            port: proxyUrl.port,
+            protocol: proxyUrl.protocol,
+            path: getPath(proxyUrl),
+            auth: getAuth(proxyUrl),
+            maxSockets: 1,
+            keepAlive: false
+        }, proxy);
 
         const isHttps = (new URL(url).protocol === 'https:');
 
         if (isHttps) {
-            const { HttpsProxyAgent } = require('hpagent');
-            return {
-                https: new HttpsProxyAgent(Object.assign({
-                    keepAlive: false,
-                    maxSockets: 1,
-                    maxFreeSockets: 1,
-                }, proxy))
-            };
+            const HttpsProxyAgent = require('https-proxy-agent');
+            const agent = new HttpsProxyAgent(options);
+            return { https: agent };
         } else {
-            const { HttpProxyAgent } = require('hpagent');
-            return {
-                http: new HttpProxyAgent(Object.assign({
-                    keepAlive: false,
-                    maxSockets: 1,
-                    maxFreeSockets: 1,
-                }, proxy))
-            };
+            const HttpProxyAgent = require('http-proxy-agent');
+            const agent = new HttpProxyAgent(options);
+            return { http: agent };
         }
     }
 

package.json

@@ -27,7 +27,8 @@
   "dependencies": {
     "debug": "^4.3.3",
     "got": "^11.8.3",
-    "hpagent": "^0.1.2",
+    "http-proxy-agent": "^5.0.0",
+    "https-proxy-agent": "^5.0.0",
     "lodash.kebabcase": "^4.1.1"
   },
   "devDependencies": {

test/helper.js

@@ -4,3 +4,5 @@ global.should = chai.should();
 global.expect = chai.expect;
 global.sinon = require('sinon');
 chai.use(require('sinon-chai'));
+
+require('hmpo-logger').config();

test/lib/spec.remote-model.js

@@ -5,7 +5,8 @@ const ModelError = require('../../lib/model-error');
 const BaseModel = require('../../lib/local-model');
 const logger = require('hmpo-logger');
 
-const { HttpProxyAgent, HttpsProxyAgent } = require('hpagent');
+const HttpsProxyAgent = require('https-proxy-agent');
+const HttpProxyAgent = require('http-proxy-agent');
 
 describe('Remote Model', () => {
     let model, cb, mocks;
@@ -71,7 +72,7 @@ describe('Remote Model', () => {
         });
 
         it('should use console log and a trimHtml pass-through if hmpo-logger is not available', () => {
-            logger.get.throws(new Error());
+            logger.get.throws({ message: 'test error' });
 
             model = new Model();
 
@@ -431,19 +432,43 @@ describe('Remote Model', () => {
                     'method': 'VERB',
                     'url': 'http://example.net',
                     'proxy': {
-                        proxy: 'http://proxy.example.com:8000',
-                        keepAlive: true
+                        uri: 'http://proxy.example.com:8000',
+                        keepAlive: true,
+                        maxSockets: 200
                     }
                 });
 
                 sinon.assert.match(returnedConfig, {
                     agent: {
                         http: {
-                            keepAlive: true
+                            proxy: {
+                                keepAlive: true,
+                                maxSockets: 200
+                            }
                         }
                     }
                 });
             });
+
+            it('should process auth for the proxy', () => {
+                let agent;
+
+                agent = model.proxy('http://username:password@host:123/path', 'https://example.com');
+                sinon.assert.match(agent.https.proxy, {
+                    auth: 'username:password',
+                    host: 'host',
+                    port: 123,
+                    protocol: 'http:'
+                });
+
+                agent = model.proxy('http://username@host:123/path', 'https://example.com');
+                sinon.assert.match(agent.https.proxy, {
+                    auth: 'username',
+                    host: 'host',
+                    port: 123,
+                    protocol: 'http:'
+                });
+            });
         });
 
         describe('with headers supplied into the constructor', () => {
@@ -742,7 +767,6 @@ describe('Remote Model', () => {
                 };
 
                 model.request(settings, cb);
-                console.log(model.logError.args[0][0]);
                 model.logError.should.have.been.calledWithExactly({
                     settings: settings,
                     statusCode: 404,