feat(object): add template option to object.new

Author: dignifiedquire

src/cli/commands/object/new.js

@@ -7,7 +7,7 @@ const log = debug('cli:object')
 log.error = debug('cli:object:error')
 
 module.exports = {
-  command: 'new',
+  command: 'new [<template>]',
 
   describe: 'Create new ipfs objects',
 
@@ -16,7 +16,7 @@ module.exports = {
   handler (argv) {
     waterfall([
       (cb) => utils.getIPFS(cb),
-      (ipfs, cb) => ipfs.object.new(cb)
+      (ipfs, cb) => ipfs.object.new(argv.template, cb)
     ], (err, node) => {
       if (err) {
         throw err

src/core/components/object.js

@@ -7,6 +7,8 @@ const DAGNode = dagPB.DAGNode
 const DAGLink = dagPB.DAGLink
 const CID = require('cids')
 const mh = require('multihashes')
+const Unixfs = require('ipfs-unixfs')
+const assert = require('assert')
 
 function normalizeMultihash (multihash, enc) {
   if (typeof multihash === 'string') {
@@ -91,8 +93,22 @@ module.exports = function object (self) {
   }
 
   return {
-    new: promisify((callback) => {
-      DAGNode.create(new Buffer(0), (err, node) => {
+    new: promisify((template, callback) => {
+      if (typeof template === 'function') {
+        callback = template
+        template = undefined
+      }
+
+      let data
+
+      if (template) {
+        assert(template === 'unixfs-dir', 'unkown template')
+        data = (new Unixfs('directory')).marshal()
+      } else {
+        data = new Buffer(0)
+      }
+
+      DAGNode.create(data, (err, node) => {
         if (err) {
           return callback(err)
         }

src/http-api/resources/object.js

@@ -34,8 +34,9 @@ exports.parseKey = (request, reply) => {
 
 exports.new = (request, reply) => {
   const ipfs = request.server.app.ipfs
+  const template = request.query.arg
 
-  ipfs.object.new((err, node) => {
+  ipfs.object.new(template, (err, node) => {
     if (err) {
       log.error(err)
       return reply({

test/cli/test-object.js

@@ -17,6 +17,14 @@ describe('object', () => {
       })
     })
 
+    it('new unixfs-dir', () => {
+      return ipfs('object new unixfs-dir').then((out) => {
+        expect(out).to.be.eql(
+          'QmUNLLsPACCz1vLxQVkXqqLX5R1X345qqfHbsf67hvA3Nn'
+        )
+      })
+    })
+
     it('get', () => {
       return ipfs('object get QmdfTbBqBPQ7VNxZEYEj14VmRuZBkqFbiwReogJgS1zR1n').then((out) => {
         const result = JSON.parse(out)