feat(dag): basics (get, put, rm)

Author: daviddias

src/core/components/dag.js

@@ -0,0 +1,39 @@
+'use strict'
+
+const promisify = require('promisify-es6')
+
+const dagPB = require('ipld-dag-pb')
+const dagCBOR = require('ipld-dag-cbor')
+
+module.exports = function dag (self) {
+  return {
+    put: promisify((dagNode, multicodec, hashAlg, callback) => {
+      switch (multicodec) {
+        case 'dag-pb': dagPB.util.cid(dagNode, gotCid); break
+        case 'dag-cbor': dagCBOR.util.cid(dagNode, gotCid); break
+        default: callback(new Error('IPLD Format not supported'))
+      }
+
+      function gotCid (err, cid) {
+        if (err) {
+          return callback(err)
+        }
+        self._ipldResolver.put({
+          node: dagNode,
+          cid: cid
+        }, callback)
+      }
+    }),
+    get: promisify((cid, callback) => {
+      self._ipldResolver.get(cid, callback)
+    }),
+    rm: promisify((cid, callback) => {
+      // TODO once pinning is complete, this remove operation has to first
+      // verify that some pinning chain is not broken with the operation
+      self._ipldResolver.remove(cid, callback)
+    }),
+    resolve: promisify((cid, path, callback) => {
+      self._ipldResolver.resolve(cid, path, callback)
+    })
+  }
+}

src/core/index.js

@@ -18,6 +18,7 @@ const bootstrap = require('./components/bootstrap')
 const config = require('./components/config')
 const block = require('./components/block')
 const object = require('./components/object')
+const dag = require('./components/dag')
 const libp2p = require('./components/libp2p')
 const swarm = require('./components/swarm')
 const ping = require('./components/ping')
@@ -64,6 +65,7 @@ function IPFS (repoInstance) {
   this.config = config(this)
   this.block = block(this)
   this.object = object(this)
+  this.dag = dag(this)
   this.libp2p = libp2p(this)
   this.swarm = swarm(this)
   this.files = files(this)

test/core/interface/dag.js

@@ -0,0 +1,20 @@
+/* eslint-env mocha */
+
+'use strict'
+
+const test = require('interface-ipfs-core')
+const IPFSFactory = require('../../utils/factory-core')
+
+let factory
+
+const common = {
+  setup: function (cb) {
+    factory = new IPFSFactory()
+    cb(null, factory)
+  },
+  teardown: function (cb) {
+    factory.dismantle(cb)
+  }
+}
+
+test.dag(common)

test/core/interface/interface.spec.js

@@ -10,6 +10,7 @@ describe('interface-ipfs-core tests', () => {
   require('./files')
   require('./generic')
   require('./object')
+  require('./dag')
   if (isNode) {
     require('./swarm')
     require('./pubsub')