object create

Author: daviddias

src/cli/commands/config.js

@@ -24,7 +24,7 @@ module.exports = Command.extend({
 
   run: (bool, json, key, value) => {
     if (!key) {
-      throw new Error('argument \'key\' is required')
+      throw new Error("argument 'key' is required")
     }
 
     var node = new IPFS()

src/ipfs-core/index.js

@@ -2,10 +2,11 @@
 
 const defaultRepo = require('./default-repo')
 // const bl = require('bl')
-// const MerkleDAG = require('ipfs-merkle-dag')
 const blocks = require('ipfs-blocks')
 const BlockService = blocks.BlockService
+const Block = blocks.Block
 // const Block = MerkleDAG.Block
+const mDAG = require('ipfs-merkle-dag')
 
 exports = module.exports = IPFS
 
@@ -153,4 +154,36 @@ function IPFS (repo) {
       })
     }
   }
+
+  this.object = {
+    // named `new` in go-ipfs
+    create: (template, callback) => {
+      if (!callback) {
+        callback = template
+      }
+      var node = new mDAG.DAGNode()
+      var block = new Block(node.marshal())
+      bs.addBlock(block, function (err) {
+        if (err) {
+          return callback(err)
+        }
+        callback(null, {
+          Hash: block.key,
+          Size: node.size(),
+          Name: ''
+        })
+      })
+    },
+    patch: (multihash, options, callback) => {},
+    data: (multihash, callback) => {},
+    links: (multihash, callback) => {},
+    get: (multihash, options, callback) => {
+      if (typeof options === 'function') {
+        callback = options
+        options = {}
+      }
+    },
+    put: (multihash, options, callback) => {},
+    stat: (multihash, options, callback) => {}
+  }
 }

tests/test-cli/test-config.js

@@ -77,7 +77,7 @@ describe('config', () => {
   it('call config with no arguments', done => {
     nexpect.spawn('node', [process.cwd() + '/src/cli/bin.js', 'config'])
       .run((err, stdout, exitcode) => {
-        const expected = 'error	argument \'key\' is required'
+        const expected = "error	argument 'key' is required"
         expect(stdout[0]).to.equal(expected)
         expect(err).to.not.exist
         expect(exitcode).to.equal(1)

tests/test-core/browser.js

@@ -7,9 +7,9 @@ const _ = require('lodash')
 const repoContext = require.context('buffer!./../repo-example', true)
 
 const idb = window.indexedDB ||
-        window.mozIndexedDB ||
-        window.webkitIndexedDB ||
-        window.msIndexedDB
+  window.mozIndexedDB ||
+  window.webkitIndexedDB ||
+  window.msIndexedDB
 
 idb.deleteDatabase('ipfs')
 idb.deleteDatabase('ipfs/blocks')

tests/test-core/test-block.js

@@ -61,7 +61,7 @@ describe('block', function () {
 
   it('stat', function (done) {
     const mh = new Buffer(base58
-        .decode('QmVtU7ths96fMgZ8YSZAbKghyieq7AjxNdcqyVzxTt3qVe'))
+      .decode('QmVtU7ths96fMgZ8YSZAbKghyieq7AjxNdcqyVzxTt3qVe'))
     ipfs.block.stat(mh, (err, stats) => {
       expect(err).to.not.exist
       expect(stats.Key.equals(mh)).to.equal(true)

tests/test-core/test-config.js

@@ -90,12 +90,12 @@ describe('config', () => {
     })
   })
 
-  // cli only feature built with show and replace
-  // it.skip('edit', done => {
-  //   const ipfs = new IPFS()
-  //  ipfs.config((err, config) => {
-  //    expect(err).to.not.exist
-  //    done()
-  //  })
-  // })
+// cli only feature built with show and replace
+// it.skip('edit', done => {
+//   const ipfs = new IPFS()
+//  ipfs.config((err, config) => {
+//    expect(err).to.not.exist
+//    done()
+//  })
+// })
 })

tests/test-core/test-object.js

@@ -0,0 +1,90 @@
+/* globals describe, before, it */
+
+'use strict'
+
+const expect = require('chai').expect
+const IPFS = require('../../src/ipfs-core')
+// const bs58 = require('bs58')
+// const Block = require('ipfs-merkle-dag').Block
+
+// TODO use arrow funtions again when https://github.com/webpack/webpack/issues/1944 is fixed
+describe('object', function () {
+  var ipfs
+
+  before(function (done) {
+    ipfs = new IPFS()
+    done()
+  })
+
+  it('create', function (done) {
+    ipfs.object.create(function (err, obj) {
+      expect(err).to.not.exist
+      expect(obj).to.have.property('Hash')
+      expect(obj).to.have.property('Size')
+      expect(obj).to.have.property('Name')
+      // depends on https://github.com/ipfs/go-ipfs/issues/2271
+      // expect(bs58.encode(obj.Hash).toString())
+      //   .to.equal('QmdfTbBqBPQ7VNxZEYEj14VmRuZBkqFbiwReogJgS1zR1n')
+      expect(obj.Size).to.equal(2)
+      done()
+    })
+  })
+
+  it.skip('patch append-data', function (done) {
+
+  })
+
+  it.skip('patch add-link', function (done) {
+
+  })
+
+  it.skip('patch rm-link', function (done) {
+
+  })
+
+  it.skip('patch set-data', function (done) {
+
+  })
+
+  it.skip('patch append-data go-ipfs mDAG obj', function (done) {
+
+  })
+
+  it.skip('patch add-link go-ipfs mDAG obj', function (done) {
+
+  })
+
+  it.skip('patch rm-link go-ipfs mDAG obj', function (done) {
+
+  })
+
+  it.skip('patch set-data go-ipfs mDAG obj', function (done) {
+
+  })
+
+  it.skip('data', function (done) {
+
+  })
+
+  it.skip('links', function (done) {
+
+  })
+
+  it.skip('get', function (done) {
+
+  })
+
+  it.skip('get cycle', function (done) {
+    // 1. get a go-ipfs marshaled DAG Node
+    // 2. store it and fetch it again
+    // 3. check if still matches (ipfs-merkle-dag should not mangle it)
+  })
+
+  it.skip('put', function (done) {
+
+  })
+
+  it.skip('stat', function (done) {
+
+  })
+})