chore: Create DAGLink list instead of passing existing links through

src/core/read.js

@@ -2,7 +2,6 @@
 
 const exporter = require('ipfs-unixfs-engine').exporter
 const promisify = require('promisify-es6')
-const CID = require('cids')
 const pull = require('pull-stream/pull')
 const collect = require('pull-stream/sinks/collect')
 const waterfall = require('async/waterfall')
@@ -39,11 +38,9 @@ module.exports = function mfsRead (ipfs) {
         parents: false
       }, done),
       (result, done) => {
-        log('traversed to', result)
-
         waterfall([
           (next) => pull(
-            exporter(new CID(result.node.multihash), ipfs._ipld, {
+            exporter(result.node.multihash, ipfs._ipld, {
               offset: options.offset,
               length: options.length
             }),
@@ -56,10 +53,6 @@ module.exports = function mfsRead (ipfs) {
           (data, next) => next(null, Buffer.concat(data))
         ], done)
       }
-    ], (error, result) => {
-      log('Read result', error, result)
-
-      callback(error, result)
-    })
+    ], callback)
   })
 }

src/core/stat.js

@@ -8,7 +8,6 @@ const {
   traverseTo
 } = require('./utils')
 const waterfall = require('async/waterfall')
-const log = require('debug')('mfs:stat')
 
 const defaultOptions = {
   hash: false,
@@ -34,8 +33,6 @@ module.exports = function mfsStat (ipfs) {
     waterfall([
       (done) => traverseTo(ipfs, path, options, done),
       ({ node }, done) => {
-        log('Traversed to', node)
-
         if (options.hash) {
           return done(null, {
             hash: bs58.encode(node.multihash)
@@ -47,7 +44,6 @@ module.exports = function mfsStat (ipfs) {
         }
 
         const meta = unmarshal(node.data)
-        log('Node meta', meta)
 
         let size = 0
 

src/core/utils/add-link.js

@@ -0,0 +1,53 @@
+'use strict'
+
+const CID = require('cids')
+const dagPb = require('ipld-dag-pb')
+const {
+  DAGNode,
+  DAGLink
+} = dagPb
+const waterfall = require('async/waterfall')
+
+const addLink = (ipfs, options, callback) => {
+  options = Object.assign({}, {
+    parent: undefined,
+    child: undefined,
+    name: undefined,
+    flush: true
+  }, options)
+
+  if (!options.parent) {
+    return callback(new Error('No parent passed to addLink'))
+  }
+
+  if (!options.child) {
+    return callback(new Error('No child passed to addLink'))
+  }
+
+  if (!options.name) {
+    return callback(new Error('No name passed to addLink'))
+  }
+
+  waterfall([
+    (done) => {
+      // Remove the old link if necessary
+      DAGNode.rmLink(options.parent, options.name, done)
+    },
+    (parent, done) => {
+      // Add the new link to the parent
+      DAGNode.addLink(parent, new DAGLink(options.name, options.child.size, options.child.hash || options.child.multihash), done)
+    },
+    (parent, done) => {
+      if (!options.flush) {
+        return done()
+      }
+
+      // Persist the new parent DAGNode
+      ipfs.dag.put(parent, {
+        cid: new CID(parent.hash || parent.multihash)
+      }, (error) => done(error, parent))
+    }
+  ], callback)
+}
+
+module.exports = addLink