feat: upgrade to awesome dag-pb

Author: daviddias

src/add-to-dagnode-transform.js

@@ -13,16 +13,16 @@ module.exports = (err, res, send, done) => {
 
   map(res, (entry, next) => waterfall([
     (cb) => getDagNode(send, entry.Hash, cb),
-    (node, cb) => node.size((err, size) => {
+    (node, cb) => {
       if (err) {
         return cb(err)
       }
 
       cb(null, {
         path: entry.Name,
         hash: entry.Hash,
-        size: size
+        size: node.size
       })
-    })
+    }
   ], next), done)
 }

src/api/object.js

@@ -46,14 +46,17 @@ module.exports = (send) => {
           return callback(err)
         }
 
-        const node = new DAGNode(result.Data, result.Links.map(
-          (l) => {
-            return new DAGLink(l.Name, l.Size, new Buffer(bs58.decode(l.Hash)))
-          }))
-
-        cache.set(multihash, node)
+        const links = result.Links.map((l) => {
+          return new DAGLink(l.Name, l.Size, new Buffer(bs58.decode(l.Hash)))
+        })
 
-        callback(null, node)
+        DAGNode.create(result.Data, links, (err, node) => {
+          if (err) {
+            return callback(err)
+          }
+          cache.set(multihash, node)
+          callback(null, node)
+        })
       })
     }),
 
@@ -125,23 +128,26 @@ module.exports = (send) => {
           })
           return
         } else {
-          node = new DAGNode(obj.Data, obj.Links)
-        }
-        next()
-
-        function next () {
-          node.toJSON((err, nodeJSON) => {
+          DAGNode.create(obj.Data, obj.Links, (err, _node) => {
             if (err) {
               return callback(err)
             }
-            if (nodeJSON.Hash !== result.Hash) {
-              return callback(new Error('Stored object was different from constructed object'))
-            }
+            node = _node
+            next()
+          })
+          return
+        }
+        next()
 
-            cache.set(result.Hash, node)
+        function next () {
+          const nodeJSON = node.toJSON()
+          if (nodeJSON.multihash !== result.Hash) {
+            const err = new Error('multihashes do not match')
+            return callback(err)
+          }
 
-            callback(null, node)
-          })
+          cache.set(result.Hash, node)
+          callback(null, node)
         }
       })
     }),
@@ -248,14 +254,13 @@ module.exports = (send) => {
           return callback(err)
         }
 
-        const node = new DAGNode()
-        node.toJSON((err, nodeJSON) => {
+        DAGNode.create(new Buffer(0), (err, node) => {
           if (err) {
             return callback(err)
           }
 
-          if (nodeJSON.Hash !== result.Hash) {
-            return callback(new Error('Stored object was different from constructed object'))
+          if (node.toJSON.multihash !== result.Hash) {
+            return callback(new Error('multihahes do not match'))
           }
 
           callback(null, node)

src/get-dagnode.js

@@ -34,14 +34,13 @@ module.exports = function (send, hash, callback) {
       var stream = res[1]
 
       if (Buffer.isBuffer(stream)) {
-        callback(err, new DAGNode(stream, object.Links))
+        DAGNode.create(stream, object.Links, callback)
       } else {
         stream.pipe(bl(function (err, data) {
           if (err) {
             return callback(err)
           }
-
-          callback(err, new DAGNode(data, object.Links))
+          DAGNode.create(data, object.Links, callback)
         }))
       }
     })