From 7cd4ae9609e8d47f16f9bba03a337de76d75fe1c Mon Sep 17 00:00:00 2001
From: Alan Shaw <alan@tableflip.io>
Date: Thu, 31 Aug 2017 16:01:52 +0100
Subject: [PATCH 1/2] Allow pass querystring options to files.add

---
 src/files/add.js   | 11 +++++++++--
 test/files.spec.js | 26 ++++++++++++++++++++++++++
 2 files changed, 35 insertions(+), 2 deletions(-)

diff --git a/src/files/add.js b/src/files/add.js
index 7fcc46e1b..d5aac24c5 100644
--- a/src/files/add.js
+++ b/src/files/add.js
@@ -5,7 +5,14 @@ const promisify = require('promisify-es6')
 const DAGNodeStream = require('../utils/dagnode-stream')
 
 module.exports = (send) => {
-  return promisify((files, callback) => {
+  return promisify((files, opts, callback) => {
+    if (typeof opts === 'function') {
+      callback = opts
+      opts = {}
+    }
+
+    opts = opts || {}
+
     const ok = Buffer.isBuffer(files) ||
                isStream.readable(files) ||
                Array.isArray(files)
@@ -14,7 +21,7 @@ module.exports = (send) => {
       return callback(new Error('"files" must be a buffer, readable stream, or array of objects'))
     }
 
-    const request = { path: 'add', files: files }
+    const request = { path: 'add', files: files, qs: opts }
 
     // Transform the response stream to DAGNode values
     const transform = (res, callback) => DAGNodeStream.streamToValue(send, res, callback)
diff --git a/test/files.spec.js b/test/files.spec.js
index ea1388ba4..d5712fe62 100644
--- a/test/files.spec.js
+++ b/test/files.spec.js
@@ -45,6 +45,20 @@ describe('.files (the MFS API part)', () => {
       })
     })
 
+    it('files.add with cid-version=1 and raw-leaves=false', (done) => {
+      const expectedHash = 'zdj7Wh9x6gXdg4UAqhRYnjBTw9eJF7hvzUU4HjpnZXHYQz9jK'
+      const options = { 'cid-version': 1, 'raw-leaves': false }
+
+      ipfs.files.add(testfile, options, (err, res) => {
+        expect(err).to.not.exist()
+
+        expect(res).to.have.length(1)
+        expect(res[0].hash).to.equal(expectedHash)
+        expect(res[0].path).to.equal(expectedHash)
+        done()
+      })
+    })
+
     it('files.mkdir', (done) => {
       ipfs.files.mkdir('/test-folder', done)
     })
@@ -170,6 +184,18 @@ describe('.files (the MFS API part)', () => {
   })
 
   describe('Promise API', () => {
+    it('files.add with cid-version=1 and raw-leaves=false', () => {
+      const expectedHash = 'zdj7Wh9x6gXdg4UAqhRYnjBTw9eJF7hvzUU4HjpnZXHYQz9jK'
+      const options = { 'cid-version': 1, 'raw-leaves': false }
+
+      return ipfs.files.add(testfile, options)
+        .then((res) => {
+          expect(res).to.have.length(1)
+          expect(res[0].hash).to.equal(expectedHash)
+          expect(res[0].path).to.equal(expectedHash)
+        })
+    })
+
     it('files.mkdir', () => {
       return ipfs.files.mkdir('/test-folder')
     })

From 4dc2d83ddcc8a8c68b971dd9e638d0e1da8e6f16 Mon Sep 17 00:00:00 2001
From: Alan Shaw <alan@tableflip.io>
Date: Fri, 1 Sep 2017 12:50:41 +0100
Subject: [PATCH 2/2] Pass qs options to createAddStream also

---
 src/files/create-add-stream.js |  2 +-
 src/utils/get-dagnode.js       | 10 ++++++++--
 2 files changed, 9 insertions(+), 3 deletions(-)

diff --git a/src/files/create-add-stream.js b/src/files/create-add-stream.js
index f17780b48..16b3a3a15 100644
--- a/src/files/create-add-stream.js
+++ b/src/files/create-add-stream.js
@@ -24,7 +24,7 @@ module.exports = (send) => {
     }
 
     ds.end = () => {
-      add(tuples, (err, res) => {
+      add(tuples, options, (err, res) => {
         if (err) {
           return ds.emit('error', err)
         }
diff --git a/src/utils/get-dagnode.js b/src/utils/get-dagnode.js
index d9942d99c..02cc8e139 100644
--- a/src/utils/get-dagnode.js
+++ b/src/utils/get-dagnode.js
@@ -2,16 +2,22 @@
 
 const DAGNode = require('ipld-dag-pb').DAGNode
 const parallel = require('async/parallel')
+const CID = require('cids')
+const mh = require('multihashes')
 const streamToValue = require('./stream-to-value')
 
 module.exports = function (send, hash, callback) {
+  // Until js-ipfs supports object/get and object/data by CID
+  // we need to convert our CID or multihash hash into a multihash
+  const multihash = mh.toB58String(new CID(hash).multihash)
+
   // Retrieve the object and its data in parallel, then produce a DAGNode
   // instance using this information.
   parallel([
     function get (done) {
       send({
         path: 'object/get',
-        args: hash
+        args: multihash
       }, done)
     },
 
@@ -21,7 +27,7 @@ module.exports = function (send, hash, callback) {
       // See https://github.com/ipfs/go-ipfs/issues/1582 for more details.
       send({
         path: 'object/data',
-        args: hash
+        args: multihash
       }, done)
     }],