jsipfs files add feature

karma.conf.js

@@ -21,7 +21,8 @@ module.exports = function (config) {
       },
       externals: {
         fs: '{}',
-        'node-forge': 'forge'
+        'node-forge': 'forge',
+        'ipfs-data-importing': '{ import: {} }'
       },
       node: {
         Buffer: true

package.json

@@ -82,6 +82,7 @@
     "hapi": "^12.0.0",
     "ipfs-api": "^2.13.1",
     "ipfs-blocks": "^0.1.0",
+    "ipfs-data-importing": "^0.3.0",
     "ipfs-merkle-dag": "^0.2.1",
     "ipfs-multipart": "^0.1.0",
     "ipfs-repo": "^0.5.0",

src/cli/commands/files/add.js

@@ -0,0 +1,33 @@
+'use strict'
+
+const Command = require('ronin').Command
+const IPFS = require('../../../ipfs-core')
+const debug = require('debug')
+const log = debug('cli:version')
+log.error = debug('cli:version:error')
+const bs58 = require('bs58')
+
+module.exports = Command.extend({
+  desc: 'Add a file to IPFS using the UnixFS data format',
+
+  options: {
+    recursive: {
+      alias: 'r',
+      type: 'boolean',
+      default: false
+    }
+  },
+
+  run: (recursive, path) => {
+    var node = new IPFS()
+    path = process.cwd() + '/' + path
+    node.files.add(path, {
+      recursive: recursive
+    }, (err, stats) => {
+      if (err) {
+        return console.log(err)
+      }
+      console.log('added', bs58.encode(stats.Hash).toString(), stats.Name)
+    })
+  }
+})

src/http-api/resources/config.js

@@ -140,7 +140,7 @@ exports.replace = {
     }
 
     const parser = multipart.reqParser(request.payload)
-    let file
+    var file
 
     parser.on('file', (fileName, fileStream) => {
       fileStream.on('data', (data) => {

src/http-api/resources/object.js

@@ -104,7 +104,7 @@ exports.put = {
     }
 
     const parser = multipart.reqParser(request.payload)
-    let file
+    var file
 
     parser.on('file', (fileName, fileStream) => {
       fileStream.on('data', (data) => {

src/ipfs-core/index.js

@@ -11,6 +11,7 @@ const DAGService = mDAG.DAGService
 const Id = require('peer-id')
 const Info = require('peer-info')
 const multiaddr = require('multiaddr')
+const importer = require('ipfs-data-importing').import
 
 exports = module.exports = IPFS
 
@@ -320,6 +321,14 @@ function IPFS (repo) {
     records: {},
     ping: notImpl
   }
+
+  this.files = {
+    add: (path, options, callback) => {
+      options.path = path
+      options.dagService = dagS
+      importer(options, callback)
+    }
+  }
 }
 
 function notImpl () {