feat!: upgrade to esm libp2p/ipfs

.aegir.cjs → .aegir.js

@@ -1,8 +1,23 @@
-'use strict'
+import path from 'path'
+import { createServer } from 'ipfsd-ctl'
+import { sigServer } from '@libp2p/webrtc-star-signalling-server'
+import { fileURLToPath } from 'url'
+import { resolve } from 'import-meta-resolve'
 
-const path = require('path')
-const createServer = require('ipfsd-ctl').createServer
-const signaller = require('libp2p-webrtc-star-signalling-server')
+const __dirname = path.dirname(fileURLToPath(import.meta.url))
+const ipfsModule = await resolve(process.env.IPFS_JS_HTTP_MODULE || 'ipfs', import.meta.url)
+const ipfsHttpModule = await resolve(process.env.IPFS_JS_HTTP_MODULE || 'ipfs-http-client', import.meta.url)
+
+async function findGoIpfsBin () {
+  if (process.env.IPFS_GO_EXEC != null) {
+    return process.env.IPFS_GO_EXEC
+  }
+
+  const modulePath = await resolve(process.env.IPFS_GO_IPFS_MODULE || 'go-ipfs', import.meta.url)
+  const module = await import(modulePath.replace('file://', ''))
+
+  return module.path()
+}
 
 /** @type {import('aegir').Options["build"]["config"]} */
 const esbuild = {
@@ -11,33 +26,29 @@ const esbuild = {
     {
       name: 'node built ins',
       setup (build) {
-        build.onResolve({ filter: /^stream$/ }, () => {
-          return { path: require.resolve('readable-stream') }
-        })
-
         build.onResolve({ filter: /^ipfs$/ }, () => {
-          return { path: require.resolve(process.env.IPFS_JS_MODULE || 'ipfs') }
+          return { path: ipfsModule.replace('file://', '') }
         })
         build.onResolve({ filter: /^ipfs-http-client$/ }, () => {
-          return { path: require.resolve(process.env.IPFS_JS_HTTP_MODULE || 'ipfs-http-client') }
+          return { path: ipfsHttpModule.replace('file://', '') }
         })
       }
     }
   ]
 }
 
-const ipfsHttpModule = require(process.env.IPFS_JS_HTTP_MODULE || 'ipfs-http-client')
-const ipfsModule = require(process.env.IPFS_JS_MODULE || 'ipfs')
-
 /** @type {import('aegir').PartialOptions} */
-module.exports = {
+export default {
   test: {
     browser: {
       config: {
         buildConfig: esbuild
       }
     },
     async before (options) {
+      const ipfsHttpModule = await import(process.env.IPFS_JS_HTTP_MODULE || 'ipfs-http-client')
+      const ipfsModule = await import(process.env.IPFS_JS_MODULE || 'ipfs')
+
       if (options.runner !== 'node') {
         const ipfsdServer = await createServer({
           host: '127.0.0.1',
@@ -48,7 +59,7 @@ module.exports = {
           ipfsHttpModule
         }, {
           go: {
-            ipfsBin: process.env.IPFS_GO_EXEC || require(process.env.IPFS_GO_IPFS_MODULE || 'go-ipfs').path()
+            ipfsBin: await findGoIpfsBin()
           },
           js: {
             ipfsOptions: {
@@ -65,11 +76,12 @@ module.exports = {
           }
         }).start()
 
-        const signallingServer = await signaller.start({
+        const signallingServer = await sigServer({
           port: 24642,
           host: '0.0.0.0',
           metrics: false
         })
+
         return {
           ipfsdServer,
           signallingServer