Added node-fetch support

README.md

@@ -100,6 +100,21 @@ needle('get', 'http://localhost:9200', {
 })
 ```
 
+### [node-fetch](https://github.com/node-fetch/node-fetch)
+
+```js
+fetch('http://localhost:9200', {
+  agent: new HttpProxyAgent({
+    keepAlive: true,
+    keepAliveMsecs: 1000,
+    maxSockets: 256,
+    maxFreeSockets: 256,
+    scheduling: 'lifo',
+    proxy: 'http://localhost:8080'
+  })
+})
+```
+
 ## License
 
 This software is licensed under the [MIT](./LICENSE).

package.json

@@ -40,6 +40,7 @@
     "ava": "^3.10.1",
     "got": "^11.5.1",
     "needle": "^2.5.0",
+    "node-fetch": "^2.6.0",
     "proxy": "^1.0.2",
     "standard": "^14.3.4",
     "tsd": "^0.13.1"

test/node-fetch.test.js

@@ -0,0 +1,103 @@
+'use strict'
+
+const fetch = require('node-fetch')
+const test = require('ava')
+const {
+  createServer,
+  createSecureServer,
+  createProxy,
+  createSecureProxy
+} = require('./utils')
+const { HttpProxyAgent, HttpsProxyAgent } = require('../')
+
+test('http to http', async t => {
+  const server = await createServer()
+  const proxy = await createProxy()
+  server.on('request', (req, res) => res.end('ok'))
+
+  const response = await fetch(`http://${server.address().address}:${server.address().port}`, {
+    agent: new HttpProxyAgent({
+      keepAlive: true,
+      keepAliveMsecs: 1000,
+      maxSockets: 256,
+      maxFreeSockets: 256,
+      scheduling: 'lifo',
+      proxy: `http://${proxy.address().address}:${proxy.address().port}`
+    })
+  })
+
+  t.is(await response.text(), 'ok')
+  t.is(response.status, 200)
+
+  server.close()
+  proxy.close()
+})
+
+test('https to http', async t => {
+  const server = await createServer()
+  const proxy = await createSecureProxy()
+  server.on('request', (req, res) => res.end('ok'))
+
+  const response = await fetch(`http://${server.address().address}:${server.address().port}`, {
+    agent: new HttpProxyAgent({
+      keepAlive: true,
+      keepAliveMsecs: 1000,
+      maxSockets: 256,
+      maxFreeSockets: 256,
+      scheduling: 'lifo',
+      proxy: `https://${proxy.address().address}:${proxy.address().port}`
+    })
+  })
+
+  t.is(await response.text(), 'ok')
+  t.is(response.status, 200)
+
+  server.close()
+  proxy.close()
+})
+
+test('http to https', async t => {
+  const server = await createSecureServer()
+  const proxy = await createProxy()
+  server.on('request', (req, res) => res.end('ok'))
+
+  const response = await fetch(`https://${server.address().address}:${server.address().port}`, {
+    agent: new HttpsProxyAgent({
+      keepAlive: true,
+      keepAliveMsecs: 1000,
+      maxSockets: 256,
+      maxFreeSockets: 256,
+      scheduling: 'lifo',
+      proxy: `http://${proxy.address().address}:${proxy.address().port}`
+    })
+  })
+
+  t.is(await response.text(), 'ok')
+  t.is(response.status, 200)
+
+  server.close()
+  proxy.close()
+})
+
+test('https to https', async t => {
+  const server = await createSecureServer()
+  const proxy = await createSecureProxy()
+  server.on('request', (req, res) => res.end('ok'))
+
+  const response = await fetch(`https://${server.address().address}:${server.address().port}`, {
+    agent: new HttpsProxyAgent({
+      keepAlive: true,
+      keepAliveMsecs: 1000,
+      maxSockets: 256,
+      maxFreeSockets: 256,
+      scheduling: 'lifo',
+      proxy: `https://${proxy.address().address}:${proxy.address().port}`
+    })
+  })
+
+  t.is(await response.text(), 'ok')
+  t.is(response.status, 200)
+
+  server.close()
+  proxy.close()
+})