migrate object api to async dag-pb

Author: daviddias

package.json

@@ -2,7 +2,7 @@
   "name": "ipfs-api",
   "version": "9.0.0",
   "description": "A client library for the IPFS HTTP API. Follows interface-ipfs-core spec",
-  "main": "src/index.js",
+  "main": "lib/index.js",
   "jsnext:main": "src/index.js",
   "scripts": {
     "test": "node --max_old_space_size=4096 node_modules/.bin/gulp test:node",
@@ -25,7 +25,7 @@
     "flatmap": "0.0.3",
     "glob": "^7.1.1",
     "ipfs-block": "^0.4.0",
-    "ipld-dag-pb": "^0.1.2",
+    "ipld-dag-pb": "^0.1.3",
     "is-ipfs": "^0.2.0",
     "isstream": "^0.1.2",
     "multiaddr": "^2.0.2",
@@ -51,7 +51,7 @@
     "chai": "^3.5.0",
     "gulp": "^3.9.1",
     "hapi": "^15.2.0",
-    "interface-ipfs-core": "^0.15.0",
+    "interface-ipfs-core": "^0.16.1",
     "ipfsd-ctl": "^0.16.0",
     "pre-commit": "^1.1.3",
     "socket.io": "^1.5.1",

src/api/object.js

@@ -94,21 +94,37 @@ module.exports = (send) => {
             obj = JSON.parse(obj.toString())
           }
         }
+
         let node
+
         if (obj.multihash) {
           node = obj
         } else if (options.enc === 'protobuf') {
-          node = new DAGNode()
-          node.unMarshal(obj)
+          dagPB.util.deserialize(obj, (err, _node) => {
+            if (err) {
+              return callback(err)
+            }
+            node = _node
+            next()
+          })
+          return
         } else {
           node = new DAGNode(obj.Data, obj.Links)
         }
-
-        if (node.toJSON().Hash !== result.Hash) {
-          return callback(new Error('Stored object was different from constructed object'))
+        next()
+
+        function next () {
+          node.toJSON((err, nodeJSON) => {
+            if (err) {
+              return callback(err)
+            }
+            if (nodeJSON.Hash !== result.Hash) {
+              return callback(new Error('Stored object was different from constructed object'))
+            }
+
+            callback(null, node)
+          })
         }
-
-        callback(null, node)
       })
     }),
     data: promisify((multihash, options, callback) => {
@@ -201,13 +217,19 @@ module.exports = (send) => {
         if (err) {
           return callback(err)
         }
+
         const node = new DAGNode()
+        node.toJSON((err, nodeJSON) => {
+          if (err) {
+            return callback(err)
+          }
 
-        if (node.toJSON().Hash !== result.Hash) {
-          return callback(new Error('Stored object was different from constructed object'))
-        }
+          if (nodeJSON.Hash !== result.Hash) {
+            return callback(new Error('Stored object was different from constructed object'))
+          }
 
-        callback(null, node)
+          callback(null, node)
+        })
       })
     }),
     patch: {