Update scripts again

Author: jdalton

scripts/make-npm-override.js

@@ -23,7 +23,7 @@ const { globStreamLicenses } = require('@socketsecurity/registry/lib/globs')
 const { LOG_SYMBOLS, logger } = require('@socketsecurity/registry/lib/logger')
 const { runNpmScript } = require('@socketsecurity/registry/lib/npm')
 const { isObject } = require('@socketsecurity/registry/lib/objects')
-const { parallelMap } = require('@socketsecurity/registry/lib/streams')
+const { transform } = require('@socketsecurity/registry/lib/streams')
 const {
   collectIncompatibleLicenses,
   collectLicenseWarnings,
@@ -130,7 +130,7 @@ function getCompatData(props) {
 async function readLicenses(dirname) {
   const stream = await globStreamLicenses(dirname)
   const results = []
-  for await (const license of parallelMap(
+  for await (const license of transform(
     8, // Concurrency level.
     async filepath => ({
       name: path.basename(filepath),

scripts/update-licenses.js

@@ -4,7 +4,7 @@ const fs = require('node:fs/promises')
 
 const constants = require('@socketregistry/scripts/constants')
 const { globStreamLicenses } = require('@socketsecurity/registry/lib/globs')
-const { transform } = require('@socketsecurity/registry/lib/streams')
+const { parallelForEach } = require('@socketsecurity/registry/lib/streams')
 
 const { LICENSE, LICENSE_CONTENT, UTF8, ignoreGlobs, rootPath } = constants
 
@@ -14,12 +14,9 @@ void (async () => {
     ignoreOriginals: true,
     ignore: [LICENSE, 'scripts/templates', ...ignoreGlobs]
   })
-
-  for await (const licensePath of transform(
+  await parallelForEach(
     8, // Concurrency level.
-    async filepath => filepath,
+    licensePath => fs.writeFile(licensePath, LICENSE_CONTENT, UTF8),
     stream
-  )) {
-    fs.writeFile(licensePath, LICENSE_CONTENT, UTF8)
-  }
+  )
 })()