Add "addFiles" API.

Author: hackergrrl

src/add-to-dagnode-transform.js

@@ -1,3 +1,5 @@
+'use strict'
+
 const async = require('async')
 const getDagNode = require('./get-dagnode')
 

src/api/add-files.js

@@ -0,0 +1,20 @@
+'use strict'
+
+const addToDagNodesTransform = require('../add-to-dagnode-transform')
+
+module.exports = (send) => {
+  return function add (path, opts, cb) {
+    if (typeof (opts) === 'function' && cb === undefined) {
+      cb = opts
+      opts = {}
+    }
+
+    if (typeof (path) !== 'string') {
+      return cb(new Error('"path" must be a string'))
+    }
+
+    var sendWithTransform = send.withTransform(addToDagNodesTransform)
+
+    return sendWithTransform('add', null, opts, path, cb)
+  }
+}

src/api/add-url.js

@@ -1,8 +1,6 @@
 'use strict'
 
 const Wreck = require('wreck')
-const async = require('async')
-const DAGNode = require('ipfs-merkle-dag').DAGNode
 const addToDagNodesTransform = require('../add-to-dagnode-transform')
 
 module.exports = (send) => {

src/api/add.js

@@ -1,7 +1,6 @@
 'use strict'
 
 const isStream = require('isstream')
-const Wreck = require('wreck')
 const addToDagNodesTransform = require('../add-to-dagnode-transform')
 
 module.exports = (send) => {

src/get-dagnode.js

@@ -1,3 +1,5 @@
+'use strict'
+
 const DAGNode = require('ipfs-merkle-dag').DAGNode
 
 module.exports = function (send, hash, cb) {

src/load-commands.js

@@ -3,6 +3,7 @@
 function requireCommands () {
   return {
     add: require('./api/add'),
+    addFiles: require('./api/add-files'),
     addUrl: require('./api/add-url'),
     bitswap: require('./api/bitswap'),
     block: require('./api/block'),

test/api/add.spec.js

@@ -13,7 +13,7 @@ const testfileBig = fs.readFileSync(path.join(__dirname, '/../15mb.random'))
 const testfile = fs.readFileSync(path.join(__dirname, '/../testfile.txt'))
 
 describe('.add', () => {
-  it('add file', (done) => {
+  it('add buffer as tuple', (done) => {
     if (!isNode) {
       return done()
     }
@@ -63,7 +63,7 @@ describe('.add', () => {
     })
   })
 
-  it('add path', (done) => {
+  it('local fs: add file', (done) => {
     if (!isNode) {
       return done()
     }
@@ -79,8 +79,8 @@ describe('.add', () => {
     })
   })
 
-  it('add a nested dir following symlinks', (done) => {
-    apiClients.a.add(path.join(__dirname, '/../test-folder'), { recursive: true }, (err, res) => {
+  it('local fs: add nested dir (follow symlinks)', (done) => {
+    apiClients.a.addFiles(path.join(__dirname, '/../test-folder'), { recursive: true }, (err, res) => {
       if (isNode) {
         expect(err).to.not.exist
 
@@ -97,8 +97,8 @@ describe('.add', () => {
     })
   })
 
-  it('add a nested dir without following symlinks', (done) => {
-    apiClients.a.add(path.join(__dirname, '/../test-folder'), { recursive: true, followSymlinks: false }, (err, res) => {
+  it('local fs: add nested dir (don\'t follow symlinks)', (done) => {
+    apiClients.a.addFiles(path.join(__dirname, '/../test-folder'), { recursive: true, followSymlinks: false }, (err, res) => {
       if (isNode) {
         expect(err).to.not.exist