convert to esm

.aegir.js

@@ -1,24 +1,30 @@
-'use strict';
+import EchoServer from 'aegir/echo-server'
+import { format } from 'iso-url'
+import url from 'url'
+import { createRequire } from 'module'
 
-const EchoServer = require('aegir/utils/echo-server')
-const { format } =require('iso-url')
+const require = createRequire(import.meta.url)
 
 /** @type {import('aegir').Options["build"]["config"]} */
 const esbuild = {
+  format: 'esm',
   plugins: [
     {
       name: 'node built ins',
       setup (build) {
         build.onResolve({ filter: /^stream$/ }, () => {
-          return { path: require.resolve('readable-stream') }
+          return { path: require.resolve('readable-stream')  }
+        })
+        build.onResolve({filter: /^url$/}, () => {
+          return { path: require.resolve('url/') }
         })
       }
     }
   ]
 }
 
 /** @type {import('aegir').PartialOptions} */
-module.exports = {
+export default {
   build: {
     config: esbuild
   },

package.json

@@ -13,10 +13,16 @@
     "url": "https://github.com/ipfs/js-ipfs-utils/issues"
   },
   "engines": {
-    "node": ">=16.0.0",
+    "node": ">=16.8.0",
     "npm": ">=7.0.0"
   },
-  "main": "src/index.js",
+  "type": "module",
+  "exports": {
+    ".": {
+      "types": "./dist/src/index.d.ts",
+      "import": "./dist/src/index.js"
+    }
+  },
   "types": "dist/src/index.d.ts",
   "typesVersions": {
     "*": {
@@ -39,7 +45,11 @@
   "eslintConfig": {
     "extends": "ipfs",
     "env": {
-      "worker": true
+      "worker": true,
+      "es6": true
+    },
+    "parserOptions": {
+      "sourceType": "module"
     }
   },
   "release": {
@@ -155,14 +165,16 @@
     "it-to-stream": "^1.0.0",
     "merge-options": "^3.0.4",
     "nanoid": "^3.1.20",
-    "native-fetch": "^3.0.0",
+    "native-fetch": "^4.0.2",
     "node-fetch": "^2.6.8",
     "react-native-fetch-api": "^3.0.0",
-    "stream-to-it": "^0.2.2"
+    "stream-to-it": "^0.2.2",
+    "undici": "^5.21.0"
   },
   "devDependencies": {
-    "aegir": "^36.1.1",
+    "aegir": "^38.1.7",
     "delay": "^5.0.0",
+    "eslint-plugin-n": "^15.6.1",
     "events": "^3.3.0",
     "ipfs-unixfs": "^6.0.4",
     "it-drain": "^1.0.3",
@@ -171,6 +183,7 @@
     "react-native-polyfill-globals": "^3.0.0",
     "readable-stream": "^4.3.0",
     "uint8arrays": "^3.0.0",
+    "url": "^0.11.0",
     "util": "^0.12.3"
   },
   "browser": {

rn-test.config.js

@@ -1,4 +1,3 @@
-'use strict'
 
 module.exports = {
   require: require.resolve('./rn-test.require.js'),

rn-test.require.js

@@ -1,4 +1,3 @@
-'use strict'
 
 const { polyfill: polyfillReadableStream } = require('react-native-polyfill-globals/src/readable-stream')
 const { polyfill: polyfillURL } = require('react-native-polyfill-globals/src/url')

src/env.js

@@ -1,29 +1,22 @@
-'use strict'
-const isElectron = require('is-electron')
-
-const IS_ENV_WITH_DOM = typeof window === 'object' && typeof document === 'object' && document.nodeType === 9
-// @ts-ignore
-const IS_ELECTRON = isElectron()
-const IS_BROWSER = IS_ENV_WITH_DOM && !IS_ELECTRON
-const IS_ELECTRON_MAIN = IS_ELECTRON && !IS_ENV_WITH_DOM
-const IS_ELECTRON_RENDERER = IS_ELECTRON && IS_ENV_WITH_DOM
-const IS_NODE = typeof require === 'function' && typeof process !== 'undefined' && typeof process.release !== 'undefined' && process.release.name === 'node' && !IS_ELECTRON
+import isElectronFn from 'is-electron'
+const isEnvWithDom = typeof window === 'object' && typeof document === 'object' && document.nodeType === 9
+const isElectron = isElectronFn()
+const isBrowser = isEnvWithDom && !isElectron
+const isElectronMain = isElectron && !isEnvWithDom
+const isElectronRenderer = isElectron && isEnvWithDom
+const isNode = typeof process !== 'undefined' && typeof process.release !== 'undefined' && process.release.name === 'node' && !isElectron
 // @ts-ignore - we either ignore worker scope or dom scope
-const IS_WEBWORKER = typeof importScripts === 'function' && typeof self !== 'undefined' && typeof WorkerGlobalScope !== 'undefined' && self instanceof WorkerGlobalScope
-const IS_TEST = typeof process !== 'undefined' && typeof process.env !== 'undefined' && process.env.NODE_ENV === 'test'
-const IS_REACT_NATIVE = typeof navigator !== 'undefined' && navigator.product === 'ReactNative'
-
-module.exports = {
-  isTest: IS_TEST,
-  isElectron: IS_ELECTRON,
-  isElectronMain: IS_ELECTRON_MAIN,
-  isElectronRenderer: IS_ELECTRON_RENDERER,
-  isNode: IS_NODE,
+const isWebWorker = typeof importScripts === 'function' && typeof self !== 'undefined' && typeof WorkerGlobalScope !== 'undefined' && self instanceof WorkerGlobalScope
+const isTest = typeof process !== 'undefined' && typeof process.env !== 'undefined' && process.env.NODE_ENV === 'test'
+const isReactNative = typeof navigator !== 'undefined' && navigator.product === 'ReactNative'
+export {
+  isTest, isElectron, isElectronMain, isElectronRenderer, isNode,
   /**
    * Detects browser main thread  **NOT** web worker or service worker
    */
-  isBrowser: IS_BROWSER,
-  isWebWorker: IS_WEBWORKER,
-  isEnvWithDom: IS_ENV_WITH_DOM,
-  isReactNative: IS_REACT_NATIVE
+  isBrowser, isWebWorker, isEnvWithDom, isReactNative
+}
+
+export default {
+  isTest, isElectron, isElectronMain, isElectronRenderer, isNode, isBrowser, isWebWorker, isEnvWithDom, isReactNative
 }

src/fetch.browser.js

@@ -1,10 +1,12 @@
-'use strict'
 
 /**
  * @typedef {globalThis.Headers} Headers
  * @typedef {globalThis.Request} Request
  * @typedef {globalThis.Response} Response
  */
 
+import { fetch, Request, Response, Headers } from 'native-fetch'
+
 // use window.fetch if it is available, fall back to node-fetch if not
-module.exports = require('native-fetch')
+export default fetch
+export { Request, Response, Headers }

src/fetch.js

@@ -1,18 +1,22 @@
-'use strict'
-
 /**
  * @typedef {globalThis.Headers} Headers
  * @typedef {globalThis.Request} Request
  * @typedef {globalThis.Response} Response
  */
 
-const { isElectronMain } = require('./env')
-
+import { isElectronMain } from './env.js'
 // use window.fetch if it is available, fall back to node-fetch if not
 let impl = 'native-fetch'
 
 if (isElectronMain) {
   impl = 'electron-fetch'
 }
 
-module.exports = require(impl)
+const fetchImpl = await import(impl)
+
+export const fetch = fetchImpl.fetch
+export const Request = fetchImpl.Request
+export const Response = fetchImpl.Response
+export const Headers = fetchImpl.Headers
+
+export default fetch

src/fetch.rn.js

@@ -1,7 +1,5 @@
-// @ts-nocheck
-'use strict'
 // @ts-ignore
-const { Headers, Request, Response, fetch } = require('react-native-fetch-api')
+import { Headers, Request, Response, fetch } from 'react-native-fetch-api'
 
 /** @type {import('electron-fetch').default} */
 const rnFetch = fetch
@@ -11,8 +9,5 @@ const rnHeaders = Headers
 const rnRequest = Request
 /** @type {import('electron-fetch').Response} */
 const rnResponse = Response
-module.exports = rnFetch
-module.exports.Headers = rnHeaders
-module.exports.Request = rnRequest
-module.exports.Response = rnResponse
-module.exports.default = rnFetch
+export default rnFetch
+export { rnHeaders as Headers, rnRequest as Request, rnResponse as Response }

src/files/glob-source.js

@@ -1,10 +1,8 @@
-'use strict'
-
-const fsp = require('fs').promises
-const fs = require('fs')
-const glob = require('it-glob')
-const Path = require('path')
-const errCode = require('err-code')
+import fsp from 'fs/promises'
+import fs from 'fs'
+import glob from 'it-glob'
+import Path from 'path'
+import errCode from 'err-code'
 
 /**
  * Create an async iterator that yields paths that match requested glob pattern
@@ -14,7 +12,7 @@ const errCode = require('err-code')
  * @param {import('../types').GlobSourceOptions} [options] - Optional options
  * @returns {AsyncGenerator<import('../types').GlobSourceResult, void, unknown>} File objects that match glob
  */
-module.exports = async function * globSource (cwd, pattern, options) {
+export default async function * globSource (cwd, pattern, options) {
   options = options || {}
 
   if (typeof pattern !== 'string') {

src/files/url-source.js

@@ -1,6 +1,4 @@
-'use strict'
-
-const HTTP = require('../http')
+import HTTP from '../http.js'
 
 /**
  *
@@ -28,4 +26,4 @@ async function * readURLContent (url, options) {
   yield * response.iterator()
 }
 
-module.exports = urlSource
+export default urlSource

src/http.js

@@ -1,14 +1,21 @@
+/**
+ * DO NOT EDIT THIS FILE DIRECTLY.
+ * This file is generated following the conversion of
+ *
+ * @see [./src/http.js]{@link ./src/http.js}
+ *
+ **/
+import { fetch, Request, Headers } from './http/fetch.js'
+import { TimeoutError, HTTPError } from './http/error.js'
+import _toesmTemp1 from 'merge-options'
+import { URL, URLSearchParams } from 'iso-url'
+import anySignal from 'any-signal'
+import browserReableStreamToIt from 'browser-readablestream-to-it'
+import { isBrowser, isWebWorker } from './env.js'
+import all from 'it-all'
 /* eslint-disable no-undef */
-'use strict'
 
-const { fetch, Request, Headers } = require('./http/fetch')
-const { TimeoutError, HTTPError } = require('./http/error')
-const merge = require('merge-options').bind({ ignoreUndefined: true })
-const { URL, URLSearchParams } = require('iso-url')
-const anySignal = require('any-signal')
-const browserReableStreamToIt = require('browser-readablestream-to-it')
-const { isBrowser, isWebWorker } = require('./env')
-const all = require('it-all')
+const merge = _toesmTemp1.bind({ ignoreUndefined: true })
 
 /**
  * @typedef {import('stream').Readable} NodeReadableStream
@@ -94,7 +101,7 @@ class HTTP {
   async fetch (resource, options = {}) {
     /** @type {HTTPOptions} */
     const opts = merge(this.opts, options)
-    // @ts-expect-error
+    // @ts-ignore
     const headers = new Headers(opts.headers)
 
     // validate resource type
@@ -372,4 +379,4 @@ HTTP.delete = (resource, options) => new HTTP(options).delete(resource, options)
  */
 HTTP.options = (resource, options) => new HTTP(options).options(resource, options)
 
-module.exports = HTTP
+export default HTTP

src/http/error.js

@@ -1,22 +1,18 @@
-'use strict'
-
-class TimeoutError extends Error {
+export class TimeoutError extends Error {
   constructor (message = 'Request timed out') {
     super(message)
     this.name = 'TimeoutError'
   }
 }
-exports.TimeoutError = TimeoutError
 
-class AbortError extends Error {
+export class AbortError extends Error {
   constructor (message = 'The operation was aborted.') {
     super(message)
     this.name = 'AbortError'
   }
 }
-exports.AbortError = AbortError
 
-class HTTPError extends Error {
+export class HTTPError extends Error {
   /**
    * @param {Response} response
    */
@@ -26,4 +22,3 @@ class HTTPError extends Error {
     this.response = response
   }
 }
-exports.HTTPError = HTTPError

src/http/fetch.browser.js

@@ -1,8 +1,5 @@
-'use strict'
-
-const { TimeoutError, AbortError } = require('./error')
-// @ts-expect-error
-const { Response, Request, Headers, default: fetch } = require('../fetch')
+import { TimeoutError, AbortError } from './error.js'
+import fetch, { Response, Request, Headers } from '../fetch.js'
 
 /**
  * @typedef {import('../types').FetchOptions} FetchOptions
@@ -102,9 +99,8 @@ const fetchWithStreaming = fetch
  * @param {FetchOptions} options
  */
 const fetchWith = (url, options = {}) =>
-  (options.onUploadProgress != null)
-    ? fetchWithProgress(url, options)
-    : fetchWithStreaming(url, options)
+// @ts-ignore native-fetch uses different types for Request and RequestInit
+  options.onUploadProgress != null ? fetchWithProgress(url, options) : fetchWithStreaming(url, options)
 
 /**
  * Parse Headers from a XMLHttpRequest
@@ -136,8 +132,8 @@ class ResponseWithURL extends Response {
   }
 }
 
-module.exports = {
-  fetch: fetchWith,
+export {
+  fetchWith as fetch,
   Request,
   Headers
 }

src/http/fetch.js

@@ -1,5 +1,3 @@
-'use strict'
-
 /**
  * @typedef {object} fetchImpl
  * @property {globalThis.fetch} fetchImpl.fetch
@@ -8,15 +6,20 @@
  * @property {globalThis.Headers} fetchImpl.Headers
  */
 
-let implName = './fetch.node'
+let implName = './fetch.node.js'
 
 if (typeof XMLHttpRequest === 'function') {
   // Electron has `XMLHttpRequest` and should get the browser implementation
   // instead of node.
-  implName = './fetch.browser'
+  implName = './fetch.browser.js'
 }
 
 /** @type {fetchImpl} */
-const fetch = require(implName)
+const fetchImpl = await import(implName).then(m => m.default)
+
+export const fetch = fetchImpl.fetch
+export const Request = fetchImpl.Request
+export const Response = fetchImpl.Response
+export const Headers = fetchImpl.Headers
 
-module.exports = fetch
+export default fetch