feat: aegir-next

Author: daviddias

.aegir.js

@@ -1,5 +1,7 @@
 'use strict'
 
+const factory = require('./test/ipfs-factory/tasks')
+
 module.exports = {
   karma: {
     files: [{
@@ -8,5 +10,9 @@ module.exports = {
       served: true,
       included: false
     }]
+  },
+  hooks: {
+    pre: factory.start,
+    post: factory.stop
   }
-}
+}

.gitignore

@@ -1,3 +1,6 @@
+package-lock.json
+yarn.lock
+
 **/node_modules
 **/*.log
 test/setup/tmp-disposable-nodes-addrs.json

.travis.yml

@@ -13,8 +13,6 @@ matrix:
 script:
   - npm run lint
   - npm run test
-  - npm run coverage
-  - make test
 
 before_script:
   - export DISPLAY=:99.0

circle.yml

@@ -2,6 +2,10 @@ machine:
   node:
     version: stable
 
+test:
+  post:
+    - npm run coverage -- --upload
+
 dependencies:
   pre:
     - google-chrome --version

examples/bundle-browserify/index.js

@@ -6,7 +6,7 @@ var ipfs = IPFS()
 
 function store () {
   var toStore = document.getElementById('source').value
-  ipfs.add(new Buffer(toStore), function (err, res) {
+  ipfs.add(Buffer.from(toStore), function (err, res) {
     if (err || !res) {
       return console.error('ipfs add error', err, res)
     }

examples/bundle-webpack/src/App.js

@@ -25,7 +25,7 @@ class App extends React.Component {
         protocol_version: res.protocolVersion
       })
     })
-    ipfs.add([new Buffer(stringToUse)], (err, res) => {
+    ipfs.add([Buffer.from(stringToUse)], (err, res) => {
       if (err) throw err
       const hash = res[0].hash
       this.setState({added_file_hash: hash})

examples/files-api/files-api.js

@@ -1,6 +1,6 @@
 'use strict'
 
-var ipfs = require('../../src')('localhost', 5001)
+const ipfs = require('../../src')('localhost', 5001)
 
 ipfs.files.ls('/folder1', function (err, res) {
   if (err) {

examples/name-api/index.js

@@ -52,7 +52,7 @@ const addAndPublish = (e) => {
   e.preventDefault()
 
   let input = e.target.elements['text']
-  let buffer = new Buffer(input.value)
+  let buffer = Buffer.from(input.value)
 
   showStatus('adding to IPFS...', COLORS.active)
 

examples/upload-file-via-browser/src/App.js

@@ -30,14 +30,14 @@ class App extends React.Component {
     let ipfsId
     const buffer = Buffer.from(reader.result)
     this.ipfsApi.add(buffer)
-    .then((response) => {
-      console.log(response)
-      ipfsId = response[0].hash
-      console.log(ipfsId)
-      this.setState({added_file_hash: ipfsId})
-    }).catch((err) => {
-      console.error(err)
-    })
+      .then((response) => {
+        console.log(response)
+        ipfsId = response[0].hash
+        console.log(ipfsId)
+        this.setState({added_file_hash: ipfsId})
+      }).catch((err) => {
+        console.error(err)
+      })
   }
 
   arrayBufferToString (arrayBuffer) {
@@ -51,11 +51,11 @@ class App extends React.Component {
   render () {
     return (
       <div>
-        <form id="captureMedia" onSubmit={this.handleSubmit}>
-          <input type="file" onChange={this.captureFile} />
+        <form id='captureMedia' onSubmit={this.handleSubmit}>
+          <input type='file' onChange={this.captureFile} />
         </form>
         <div>
-          <a target="_blank"
+          <a target='_blank'
             href={'https://ipfs.io/ipfs/' + this.state.added_file_hash}>
             {this.state.added_file_hash}
           </a>

gulpfile.js

@@ -10,16 +10,16 @@
     "http": "stream-http"
   },
   "scripts": {
-    "test": "gulp test",
-    "test:node": "gulp test:node",
-    "test:browser": "gulp test:browser",
-    "lint": "aegir-lint",
-    "build": "gulp build",
-    "release": "gulp release",
-    "release-minor": "gulp release --type minor",
-    "release-major": "gulp release --type major",
-    "coverage": "gulp coverage",
-    "coverage-publish": "aegir-coverage publish"
+    "test": "aegir test --no-parallel",
+    "test:node": "aegir test --target node --no-parallel",
+    "test:browser": "aegir test --target browser",
+    "lint": "aegir lint",
+    "build": "aegir build",
+    "release": "aegir release --no-parallel",
+    "release-minor": "aegir release --type minor --no-parallel",
+    "release-major": "aegir release --type major --no-parallel",
+    "coverage": "aegir coverage --no-parallel --timeout 100000",
+    "coverage-publish": "aegir coverage --provider coveralls --no-parallel --timeout 100000"
   },
   "dependencies": {
     "async": "^2.5.0",
@@ -37,7 +37,7 @@
     "is-stream": "^1.1.0",
     "lru-cache": "^4.1.1",
     "multiaddr": "^2.3.0",
-    "multihashes": "~0.4.5",
+    "multihashes": "~0.4.8",
     "multipart-stream": "^2.0.1",
     "ndjson": "^1.5.0",
     "once": "^1.4.0",
@@ -52,26 +52,26 @@
     "tar-stream": "^1.5.4"
   },
   "engines": {
-    "node": ">=4.0.0",
+    "node": ">=6.0.0",
     "npm": ">=3.0.0"
   },
   "repository": {
     "type": "git",
     "url": "https://github.com/ipfs/js-ipfs-api"
   },
   "devDependencies": {
-    "aegir": "^11.0.2",
+    "aegir": "^12.0.2",
     "chai": "^4.1.1",
     "dirty-chai": "^2.0.1",
-    "eslint-plugin-react": "^7.1.0",
+    "eslint-plugin-react": "^7.3.0",
     "gulp": "^3.9.1",
     "hapi": "^16.5.2",
-    "interface-ipfs-core": "~0.30.1",
+    "interface-ipfs-core": "~0.31.8",
     "ipfsd-ctl": "~0.21.0",
     "pre-commit": "^1.2.2",
     "socket.io": "^2.0.3",
     "socket.io-client": "^2.0.3",
-    "stream-equal": "^1.0.0"
+    "stream-equal": "^1.0.1"
   },
   "pre-commit": [
     "lint",
@@ -134,4 +134,4 @@
     "url": "https://github.com/ipfs/js-ipfs-api/issues"
   },
   "homepage": "https://github.com/ipfs/js-ipfs-api"
-}
+}

package.json

@@ -6,7 +6,7 @@ const promisify = require('promisify-es6')
 module.exports = (send) => {
   return promisify((config, callback) => {
     if (typeof config === 'object') {
-      config = streamifier.createReadStream(new Buffer(JSON.stringify(config)))
+      config = streamifier.createReadStream(Buffer.from(JSON.stringify(config)))
     }
 
     send({

src/config/replace.js

@@ -45,7 +45,7 @@ module.exports = (send) => {
       }
 
       const links = result.Links.map((l) => {
-        return new DAGLink(l.Name, l.Size, new Buffer(bs58.decode(l.Hash)))
+        return new DAGLink(l.Name, l.Size, Buffer.from(bs58.decode(l.Hash)))
       })
 
       DAGNode.create(result.Data, links, (err, node) => {

src/object/get.js

@@ -46,7 +46,7 @@ module.exports = (send) => {
 
       if (result.Links) {
         links = result.Links.map((l) => {
-          return new DAGLink(l.Name, l.Size, new Buffer(bs58.decode(l.Hash)))
+          return new DAGLink(l.Name, l.Size, Buffer.from(bs58.decode(l.Hash)))
         })
       }
       callback(null, links)

src/object/links.js

@@ -27,7 +27,7 @@ module.exports = (send) => {
         }
         data = (new Unixfs('directory')).marshal()
       } else {
-        data = new Buffer(0)
+        data = Buffer.alloc(0)
       }
 
       DAGNode.create(data, (err, node) => {

src/object/new.js

@@ -52,7 +52,7 @@ module.exports = (send) => {
     if (Buffer.isBuffer(obj) && options.enc) {
       buf = obj
     } else {
-      buf = new Buffer(JSON.stringify(tmpObj))
+      buf = Buffer.from(JSON.stringify(tmpObj))
     }
     const enc = options.enc || 'json'
 
@@ -87,7 +87,7 @@ module.exports = (send) => {
         })
         return
       } else {
-        DAGNode.create(new Buffer(obj.Data), obj.Links, (err, _node) => {
+        DAGNode.create(Buffer.from(obj.Data), obj.Links, (err, _node) => {
           if (err) {
             return callback(err)
           }

src/object/put.js

@@ -8,40 +8,38 @@ module.exports = function (send, hash, callback) {
   // Retrieve the object and its data in parallel, then produce a DAGNode
   // instance using this information.
   parallel([
-    function get (done) {
+    (done) => {
       send({
         path: 'object/get',
         args: hash
       }, done)
     },
-
-    function data (done) {
+    (done) => {
       // WORKAROUND: request the object's data separately, since raw bits in JSON
       // are interpreted as UTF-8 and corrupt the data.
       // See https://github.com/ipfs/go-ipfs/issues/1582 for more details.
       send({
         path: 'object/data',
         args: hash
       }, done)
-    }],
-
-    function done (err, res) {
-      if (err) {
-        return callback(err)
-      }
+    }
+  ], (err, res) => {
+    if (err) {
+      return callback(err)
+    }
 
-      var object = res[0]
-      var stream = res[1]
+    var object = res[0]
+    var stream = res[1]
 
-      if (Buffer.isBuffer(stream)) {
-        DAGNode.create(stream, object.Links, callback)
-      } else {
-        streamToValue(stream, (err, data) => {
-          if (err) {
-            return callback(err)
-          }
-          DAGNode.create(data, object.Links, callback)
-        })
-      }
-    })
+    if (Buffer.isBuffer(stream)) {
+      DAGNode.create(stream, object.Links, callback)
+    } else {
+      streamToValue(stream, (err, data) => {
+        if (err) {
+          return callback(err)
+        }
+        DAGNode.create(data, object.Links, callback)
+      })
+    }
+  })
 }

src/utils/get-dagnode.js

@@ -24,9 +24,9 @@ function headers (file) {
 
 function strip (name, base) {
   const smallBase = base
-        .split('/')
-        .slice(0, -1)
-        .join('/') + '/'
+    .split('/')
+    .slice(0, -1)
+    .join('/') + '/'
   return name.replace(smallBase, '')
 }
 

src/utils/get-files-stream.js

@@ -27,9 +27,9 @@ function deserializeFromBase64 (obj) {
   }
 
   return {
-    from: bs58.encode(new Buffer(obj.from, 'base64')).toString(),
-    seqno: new Buffer(obj.seqno, 'base64'),
-    data: new Buffer(obj.data, 'base64'),
+    from: bs58.encode(Buffer.from(obj.from, 'base64')).toString(),
+    seqno: Buffer.from(obj.seqno, 'base64'),
+    data: Buffer.from(obj.data, 'base64'),
     topicCIDs: obj.topicIDs || obj.topicCIDs
   }
 }

src/utils/pubsub-message-utils.js

@@ -7,11 +7,12 @@ const expect = chai.expect
 chai.use(dirtyChai)
 const FactoryClient = require('./ipfs-factory/client')
 
-describe('.bitswap', () => {
+describe('.bitswap', function () {
+  this.timeout(20 * 1000) // slow CI
   let ipfs
   let fc
 
-  before(function (done) {
+  before((done) => {
     this.timeout(20 * 1000) // slow CI
     fc = new FactoryClient()
     fc.spawnNode((err, node) => {