feat: add support for js-ipfs dag api and also some tests

Author: achingbrain

package.json

@@ -50,6 +50,7 @@
     "ipfs-utils": "~0.0.3",
     "ipld-dag-cbor": "~0.15.0",
     "ipld-dag-pb": "~0.17.3",
+    "ipld-raw": "^4.0.0",
     "is-ipfs": "~0.6.1",
     "is-pull-stream": "0.0.0",
     "is-stream": "^2.0.0",

src/dag/get.js

@@ -2,14 +2,16 @@
 
 const dagPB = require('ipld-dag-pb')
 const dagCBOR = require('ipld-dag-cbor')
+const raw = require('ipld-raw')
 const promisify = require('promisify-es6')
 const CID = require('cids')
 const waterfall = require('async/waterfall')
 const block = require('../block')
 
 const resolvers = {
   'dag-cbor': dagCBOR.resolver,
-  'dag-pb': dagPB.resolver
+  'dag-pb': dagPB.resolver,
+  raw: raw.resolver
 }
 
 module.exports = (send) => {
@@ -48,7 +50,7 @@ module.exports = (send) => {
         const dagResolver = resolvers[ipfsBlock.cid.codec]
 
         if (!dagResolver) {
-          const error = new Error('ipfs-http-client is missing DAG resolver for "' + ipfsBlock.cid.codec + '" multicodec')
+          const error = new Error(`Missing IPLD format "${ipfsBlock.cid.codec}"`)
           error.missingMulticodec = ipfsBlock.cid.codec
           return cb(error)
         }
@@ -59,6 +61,7 @@ module.exports = (send) => {
         } catch (err) {
           return cb(err)
         }
+
         cb(null, res)
       }
     ], callback)

test/dag.spec.js

@@ -68,16 +68,75 @@ describe('.dag', function () {
     })
   })
 
-  it('should callback with error when missing DAG resolver for raw multicodec', (done) => {
-    ipfs.dag.put(Buffer.from([0, 1, 2, 3]), {
-      // CIDv1 with multicodec = raw
-      cid: new CID('bafkreigh2akiscaildcqabsyg3dfr6chu3fgpregiymsck7e7aqa4s52zy')
+  it('should be able to get part of a dag-cbor node', (done) => {
+    const cbor = {
+      foo: 'dag-cbor-bar'
+    }
+    ipfs.dag.put(cbor, { format: 'dag-cbor', hashAlg: 'sha2-256' }, (err, cid) => {
+      expect(err).to.not.exist()
+      expect(cid.codec).to.equal('dag-cbor')
+      cid = cid.toBaseEncodedString('base32')
+      expect(cid).to.equal('bafyreic6f672hnponukaacmk2mmt7vs324zkagvu4hcww6yba6kby25zce')
+      ipfs.dag.get(cid, 'foo', (err, result) => {
+        expect(err).to.not.exist()
+        expect(result.value).to.equal('dag-cbor-bar')
+        done()
+      })
+    })
+  })
+
+  it('should be able to traverse from one dag-cbor node to another', (done) => {
+    const cbor1 = {
+      foo: 'dag-cbor-bar'
+    }
+
+    ipfs.dag.put(cbor1, { format: 'dag-cbor', hashAlg: 'sha2-256' }, (err, cid1) => {
+      expect(err).to.not.exist()
+
+      const cbor2 = {
+        other: {
+          '/': cid1.toBaseEncodedString('base32')
+        }
+      }
+
+      ipfs.dag.put(cbor2, { format: 'dag-cbor', hashAlg: 'sha2-256' }, (err, cid2) => {
+        expect(err).to.not.exist()
+
+        ipfs.dag.get(cid2, 'other/foo', (err, result) => {
+          expect(err).to.not.exist()
+          expect(result.value).to.equal('dag-cbor-bar')
+          done()
+        })
+      })
+    })
+  })
+
+  it('should be able to put and get a DAG node with format raw', (done) => {
+    const buf = Buffer.from([0, 1, 2, 3])
+
+    ipfs.dag.put(buf, {
+      format: 'raw',
+      hashAlg: 'sha2-256'
     }, (err, cid) => {
       expect(err).to.not.exist()
 
       ipfs.dag.get(cid, (err, result) => {
+        expect(err).to.not.exist()
+        expect(result.value).to.deep.equal(buf)
+        done()
+      })
+    })
+  })
+
+  it('should callback with error when missing DAG resolver for multicodec from requested CID', (done) => {
+    ipfs.block.put(Buffer.from([0, 1, 2, 3]), {
+      cid: new CID('z8mWaJ1dZ9fH5EetPuRsj8jj26pXsgpsr')
+    }, (err, block) => {
+      expect(err).to.not.exist()
+
+      ipfs.dag.get(block.cid, (err, result) => {
         expect(result).to.not.exist()
-        expect(err.message).to.equal('ipfs-http-client is missing DAG resolver for "raw" multicodec')
+        expect(err.message).to.equal('Missing IPLD format "git-raw"')
         done()
       })
     })