Adds wiring for a progress bar

Passes the progress bar option for tranfers over http. Progress is shown for your payload being streamed upto the server. There is a pause. Then you get your list of files.

Author: bmordan

src/files/add.js

@@ -41,7 +41,7 @@ module.exports = (send) => {
       qs.hash = opts.hashAlg
     }
 
-    const request = { path: 'add', files: files, qs: qs }
+    const request = { path: 'add', files: files, qs: opts, progress: opts.progress }
 
     // Transform the response stream to DAGNode values
     const transform = (res, callback) => DAGNodeStream.streamToValue(send, res, callback)

src/utils/request-api.js

@@ -10,6 +10,7 @@ const getFilesStream = require('./get-files-stream')
 const streamToValue = require('./stream-to-value')
 const streamToJsonValue = require('./stream-to-json-value')
 const request = require('./request')
+const Transform = require('readable-stream').Transform
 
 // -- Internal
 
@@ -160,7 +161,17 @@ function requestAPI (config, options, callback) {
   })
 
   if (options.files) {
-    stream.pipe(req)
+    if (options.progress && typeof options.progress === 'function') {
+      const progressStream = new Transform({
+        transform: (chunk, encoding, cb) => {
+          options.progress(chunk.byteLength)
+          cb(null, chunk)
+        }
+      })
+      stream.pipe(progressStream).pipe(req)
+    } else {
+      stream.pipe(req)
+    }
   } else {
     req.end()
   }

test/files.spec.js

@@ -87,6 +87,15 @@ describe('.files (the MFS API part)', function () {
       })
     })
 
+    it.only('files.add with progress options', (done) => {
+      ipfs.files.add(testfile, {progress: false}, (err, res) => {
+        expect(err).to.not.exist()
+
+        expect(res).to.have.length(1)
+        done()
+      })
+    })
+
     HASH_ALGS.forEach((name) => {
       it(`files.add with hash=${name} and raw-leaves=false`, (done) => {
         const content = String(Math.random() + Date.now())