fix: complete migration to async API

package.json

@@ -47,6 +47,7 @@
   },
   "devDependencies": {
     "aegir": "8.1.2",
+    "async": "^2.1.2",
     "chai": "^3.5.0",
     "pre-commit": "^1.1.3"
   },

src/util.js

@@ -7,16 +7,20 @@ const resolver = require('./resolver')
 
 exports = module.exports
 
-exports.serialize = (dagNode) => {
-  return cbor.encode(dagNode)
+exports.serialize = (dagNode, callback) => {
+  callback(null, cbor.encode(dagNode))
 }
 
 exports.deserialize = (data, callback) => {
   cbor.decodeFirst(data, callback)
 }
 
 exports.cid = (dagNode, callback) => {
-  const serialized = exports.serialize(dagNode)
-  const mh = multihashing(serialized, 'sha2-256')
-  callback(null, new CID(1, resolver.multicodec, mh))
+  exports.serialize(dagNode, (err, serialized) => {
+    if (err) {
+      return callback(err)
+    }
+    const mh = multihashing(serialized, 'sha2-256')
+    callback(null, new CID(1, resolver.multicodec, mh))
+  })
 }

test/resolver.spec.js

@@ -6,12 +6,13 @@ const expect = require('chai').expect
 const dagCBOR = require('../src')
 const resolver = dagCBOR.resolver
 const Block = require('ipfs-block')
+const series = require('async/series')
 
 describe('IPLD format resolver (local)', () => {
   let emptyNodeBlock
   let nodeBlock
 
-  before(() => {
+  before((done) => {
     const emptyNode = {}
     const node = {
       name: 'I am a node',
@@ -25,11 +26,24 @@ describe('IPLD format resolver (local)', () => {
         { a: 'b' },
         2
       ]
-
     }
 
-    emptyNodeBlock = new Block(dagCBOR.util.serialize(emptyNode))
-    nodeBlock = new Block(dagCBOR.util.serialize(node))
+    series([
+      (cb) => {
+        dagCBOR.util.serialize(emptyNode, (err, serialized) => {
+          expect(err).to.not.exist
+          emptyNodeBlock = new Block(serialized)
+          cb()
+        })
+      },
+      (cb) => {
+        dagCBOR.util.serialize(node, (err, serialized) => {
+          expect(err).to.not.exist
+          nodeBlock = new Block(serialized)
+          cb()
+        })
+      }
+    ], done)
   })
 
   it('multicodec is dag-cbor', () => {

test/util.spec.js

@@ -11,13 +11,15 @@ describe('util', () => {
   }
 
   it('.serialize and .deserialize', (done) => {
-    const serialized = dagCBOR.util.serialize(obj)
-    expect(Buffer.isBuffer(serialized)).to.be.true
-
-    dagCBOR.util.deserialize(serialized, (err, deserialized) => {
+    dagCBOR.util.serialize(obj, (err, serialized) => {
       expect(err).to.not.exist
-      expect(obj).to.eql(deserialized)
-      done()
+      expect(Buffer.isBuffer(serialized)).to.be.true
+
+      dagCBOR.util.deserialize(serialized, (err, deserialized) => {
+        expect(err).to.not.exist
+        expect(obj).to.eql(deserialized)
+        done()
+      })
     })
   })