Replace undici with native https.request

index.js

@@ -1,7 +1,7 @@
 #!/usr/bin/env node
 
-const { request, stream, setGlobalDispatcher, Agent } = require('undici')
-const EE = require('events')
+const { request } = require('https')
+const { pipeline } = require('stream')
 const fs = require('fs')
 const path = require('path')
 const os = require('os')
@@ -10,8 +10,6 @@ const satisfies = require('semver/functions/satisfies')
 const { danger, vulnerableWarning, bold, separator, allGood } = require('./ascii')
 const nv = require('@pkgjs/nv')
 
-setGlobalDispatcher(new Agent({ connections: 20 }))
-
 const CORE_RAW_URL = 'https://raw.githubusercontent.com/nodejs/security-wg/main/vuln/core/index.json'
 
 let lastETagValue
@@ -36,28 +34,55 @@ function updateLastETag (etag) {
 }
 
 async function fetchCoreIndex () {
-  const abortRequest = new EE()
-  await stream(CORE_RAW_URL, { signal: abortRequest }, ({ statusCode }) => {
-    if (statusCode !== 200) {
-      console.error('Request to Github failed. Aborting...')
-      abortRequest.emit('abort')
-      process.nextTick(() => { process.exit(1) })
-    }
-    return fs.createWriteStream(coreLocalFile, { flags: 'w', autoClose: true })
+  await new Promise((resolve) => {
+    request(CORE_RAW_URL, (res) => {
+      if (res.statusCode !== 200) {
+        console.error('Request to Github failed. Aborting...')
+        process.nextTick(() => { process.exit(1) })
+      }
+
+      const file = fs.createWriteStream(coreLocalFile)
+      pipeline(res, file, (err) => {
+        if (err) {
+          console.error(`Problem with request: ${err.message}`)
+          process.nextTick(() => { process.exit(1) })
+        } else {
+          resolve()
+        }
+      })
+    })
   })
   return readLocal(coreLocalFile)
 }
 
 async function getCoreIndex () {
-  const { headers } = await request(CORE_RAW_URL, { method: 'HEAD' })
-  if (!lastETagValue || lastETagValue !== headers.etag || !fs.existsSync(coreLocalFile)) {
-    updateLastETag(headers.etag)
-    debug('Creating local core.json')
-    return fetchCoreIndex()
-  } else {
-    debug(`No updates from upstream. Getting a cached version: ${coreLocalFile}`)
-    return readLocal(coreLocalFile)
-  }
+  return new Promise((resolve) => {
+    const req = request(CORE_RAW_URL, { method: 'HEAD' }, (res) => {
+      if (res.statusCode !== 200) {
+        console.error('Request to Github failed. Aborting...')
+        process.nextTick(() => { process.exit(1) })
+      }
+
+      res.on('data', () => {})
+
+      const { etag } = res.headers
+      if (!lastETagValue || lastETagValue !== etag || !fs.existsSync(coreLocalFile)) {
+        updateLastETag(etag)
+        debug('Creating local core.json')
+        resolve(fetchCoreIndex())
+      } else {
+        debug(`No updates from upstream. Getting a cached version: ${coreLocalFile}`)
+        resolve(readLocal(coreLocalFile))
+      }
+    })
+
+    req.on('error', (e) => {
+      console.error(`Problem with request: ${e.message}`)
+      process.nextTick(() => { process.exit(1) })
+    })
+
+    req.end()
+  })
 }
 
 const checkPlatform = platform => {

package.json

@@ -31,8 +31,7 @@
     "@pkgjs/nv": "^0.2.1",
     "cli-color": "^2.0.3",
     "debug": "^4.3.4",
-    "semver": "^7.3.8",
-    "undici": "^5.15.1"
+    "semver": "^7.3.8"
   },
   "devDependencies": {
     "standard": "^17.0.0",