Merge pull request #270 from module-federation/release-0-1-0

get rid of unneeded lbs

Author: tysonrm

nohup.out

@@ -3261,3 +3261,17 @@ Error: Command failed: ./watch.sh 80 8888
   signal: null,
   cmd: './watch.sh 80 8888'
 }
+change adapters/datasources/datasource-ipfs.js
+Error: Command failed: ./watch.sh 80 8888
+
+    at ChildProcess.exithandler (node:child_process:402:12)
+    at ChildProcess.emit (node:events:513:28)
+    at maybeClose (node:internal/child_process:1100:16)
+    at Socket.<anonymous> (node:internal/child_process:458:11)
+    at Socket.emit (node:events:513:28)
+    at Pipe.<anonymous> (node:net:301:12) {
+  code: 7,
+  killed: false,
+  signal: null,
+  cmd: './watch.sh 80 8888'
+}

package.json

@@ -20,7 +20,8 @@
     "buildc": "gcc forkrun.c -o forkrun"
   },
   "peerDependencies": {
-    "core-js": "^3"
+    "core-js": "^3",
+    "express": "4.18.2"
   },
   "dependencies": {
     "@assemblyscript/loader": "0.25.2",
@@ -31,21 +32,15 @@
     "assemblyscript": "0.25.2",
     "cors": "^2.8.5",
     "dotenv": "16.0.1",
-    "express": "4.18.2",
     "express-fileupload": "^1.4.0",
     "express-jwt": "7.7.5",
     "import-fresh": "3.3.0",
-    "ipfs": "^0.63.0",
     "jwks-rsa": "2.1.4",
     "mesh-link": "0.13.6",
     "mongodb": "^4.12.1",
     "multicast-dns": "7.2.5",
     "nanoid": "3.3.2",
-    "nats": "2.7.1",
     "path-to-regexp": "^6.2.1",
-    "pretty": "^2.0.0",
-    "pretty-cli": "^0.0.14",
-    "python-shell": "^3.0.1",
     "query-params-mongo": "^1.1.3",
     "regenerator-runtime": "0.13.9",
     "rimraf": "3.0.2",
@@ -75,6 +70,7 @@
     "jsdoc-to-markdown": "7.1.1",
     "mocha": "10.0.0",
     "mocha-esm": "1.1.1",
+    "pretty-cli": "^0.0.14",
     "prettier": "^2.8.1",
     "split": "1.0.1",
     "standard": "^17.0.0",

src/adapters/datasources/datasource-ipfs.js

@@ -1,72 +1,72 @@
-import fs from 'fs'
-import { DataSourceFile } from '.'
-import IPFS from 'ipfs-core'
+// import fs from 'fs'
+// import { DataSourceFile } from '.'
+// import IPFS from 'ipfs-core'
 
-/**
- * Storage on the distributed web {@link https://ipfs.io}
- */
-export class DataSourceIpfs extends DataSourceFile {
-  constructor(map, name, options = {}) {
-    super(map, name, options)
-  }
+// /**
+//  * Storage on the distributed web {@link https://ipfs.io}
+//  */
+// export class DataSourceIpfs extends DataSourceFile {
+//   constructor(map, name, options = {}) {
+//     super(map, name, options)
+//   }
 
-  async save(id, data) {
-    super.save(id, data)
-    this.writeFile()
-    return data
-  }
+//   async save(id, data) {
+//     super.save(id, data)
+//     this.writeFile()
+//     return data
+//   }
 
-  async find(id) {
-    return super.find(id)
-  }
+//   async find(id) {
+//     return super.find(id)
+//   }
 
-  startIpfs() {
-    try {
-      IPFS.create({
-        repo: 'aegis-' + Math.random(),
-      }).then(fs => (this.ipfs = fs))
-    } catch (err) {
-      console.error(err)
-    }
-  }
+//   startIpfs() {
+//     try {
+//       IPFS.create({
+//         repo: 'aegis-' + Math.random(),
+//       }).then(fs => (this.ipfs = fs))
+//     } catch (err) {
+//       console.error(err)
+//     }
+//   }
 
-  load(hydrate) {
-    this.startIpfs()
-    if (fs.existsSync(this.file)) {
-      try {
-        this.cid = fs.readFileSync(this.file, 'utf-8')
-        this.readFile(hydrate)
-      } catch (error) {
-        console.error(this.load.name, error.message)
-      }
-    } else {
-      return new Map()
-    }
-  }
+//   load(hydrate) {
+//     this.startIpfs()
+//     if (fs.existsSync(this.file)) {
+//       try {
+//         this.cid = fs.readFileSync(this.file, 'utf-8')
+//         this.readFile(hydrate)
+//       } catch (error) {
+//         console.error(this.load.name, error.message)
+//       }
+//     } else {
+//       return new Map()
+//     }
+//   }
 
-  async readFile(hydrate) {
-    try {
-      let data
-      const stream = this.ipfs.cat(this.cid)
-      for await (const chunk of stream) {
-        // chunks of data are returned as a Buffer, convert it back to a string
-        data += chunk.toString()
-      }
-      return hydrate(new Map(JSON.parse(data), this.revive))
-    } catch (e) {
-      console.error(e)
-    }
-  }
+//   async readFile(hydrate) {
+//     try {
+//       let data
+//       const stream = this.ipfs.cat(this.cid)
+//       for await (const chunk of stream) {
+//         // chunks of data are returned as a Buffer, convert it back to a string
+//         data += chunk.toString()
+//       }
+//       return hydrate(new Map(JSON.parse(data), this.revive))
+//     } catch (e) {
+//       console.error(e)
+//     }
+//   }
 
-  async writeFile() {
-    try {
-      // add your data to to IPFS - this can be a string, a Buffer,
-      // a stream of Buffers, etc
-      const { cid } = this.ipfs.add(JSON.stringify([...this.dsMap]))
-      fs.writeFileSync(this.file, cid.toString())
-      this.cid = cid
-    } catch (error) {
-      console.error(error)
-    }
-  }
-}
+//   async writeFile() {
+//     try {
+//       // add your data to to IPFS - this can be a string, a Buffer,
+//       // a stream of Buffers, etc
+//       const { cid } = this.ipfs.add(JSON.stringify([...this.dsMap]))
+//       fs.writeFileSync(this.file, cid.toString())
+//       this.cid = cid
+//     } catch (error) {
+//       console.error(error)
+//     }
+//   }
+// }