Merge pull request #43 from joehand/dat.json

Dat.json

lib/commands/create.js

@@ -2,6 +2,7 @@ var logger = require('status-logger')
 var prettyBytes = require('pretty-bytes')
 var Dat = require('dat-node')
 var ui = require('../ui')
+var datJson = require('../dat-json')
 
 module.exports = {
   name: 'create',
@@ -48,19 +49,34 @@ function create (opts) {
     else output[1] = 'Creating link...' + '\n'
     if (opts.quiet && dat.key) process.stdout.write(ui.link(dat.key))
 
-    // Not importing files. Just create .dat, print info, and exit.
-    if (!opts.import) return exit()
+    if (dat.owner) {
+      datJson.read(dat, function (err, body) {
+        if (!err) return importFiles() // TODO: if dat.json exists, then what?
+        if (err.code === 'ENOENT' || !body) {
+          return datJson.create(dat, function (err) {
+            if (err) return exit(err)
+            importFiles()
+          })
+        }
+        return exit(err)
+      })
+    }
+
+    function importFiles () {
+      // Not importing files. Just create .dat, print info, and exit.
+      if (!opts.import) return exit()
 
-    output[2] = 'Importing files to archive...'
-    importStatus = dat.importFiles(function (err) {
-      if (err) return exit(err)
-      output[2] = opts.live !== false ? 'File import finished!' : 'Snapshot created!'
-      output[3] = `Total Size: ${importStatus.fileCount} ${importStatus.fileCount === 1 ? 'file' : 'files'} (${prettyBytes(importStatus.totalSize)})`
+      output[2] = 'Importing files to archive...'
+      importStatus = dat.importFiles(function (err) {
+        if (err) return exit(err)
+        output[2] = opts.live !== false ? 'File import finished!' : 'Snapshot created!'
+        output[3] = `Total Size: ${importStatus.fileCount} ${importStatus.fileCount === 1 ? 'file' : 'files'} (${prettyBytes(importStatus.totalSize)})`
 
-      if (opts.live !== false) return exit()
-      if (dat.key) output[1] = ui.link(dat.key) + '\n'
-      exit()
-    })
+        if (opts.live !== false) return exit()
+        if (dat.key) output[1] = ui.link(dat.key) + '\n'
+        exit()
+      })
+    }
   })
 
   function updateProgress () {

lib/dat-json.js

@@ -0,0 +1,31 @@
+var fs = require('fs')
+var datKeyAs = require('dat-key-as')
+var path = require('path')
+
+module.exports = {
+  read: function (dat, cb) {
+    // dat.json
+    // reads to dat.meta if exists
+    // creates dat.json if not exists with title = dir name
+    // (TODO: move to module & validate dat.json)
+    fs.readFile(datJsonFile(dat), 'utf8', function (err, body) {
+      if (err) return cb(err)
+      var meta
+      try {
+        meta = JSON.parse(body)
+      } catch (e) {
+        return cb(new Error('Error reading the dat.json file.'))
+      }
+      cb(null, meta)
+    })
+  },
+  create: function (dat, cb) {
+    dat.meta = {title: path.basename(dat.path), description: ''}
+    if (dat.key) dat.meta.url = 'dat://' + datKeyAs.str(dat.key)
+    fs.writeFile(datJsonFile(dat), JSON.stringify(dat.meta), cb)
+  }
+}
+
+function datJsonFile (dat) {
+  return path.join(dat.path, 'dat.json')
+}

tests/create.js

@@ -31,6 +31,8 @@ test('create - default opts', function (t) {
     t.ok(output.match(fileRe), 'total size: files okay')
     t.ok(output.match(bytesRe), 'total size: bytes okay')
 
+    t.same(help.datJson(fixtures).title, 'fixtures', 'dat.json: has title')
+
     st.kill()
     return true
   })

tests/helpers/index.js

@@ -13,6 +13,7 @@ var swarm = require('hyperdiscovery')
 module.exports.matchLink = matchDatLink
 module.exports.isDir = isDir
 module.exports.testFolder = newTestFolder
+module.exports.datJson = datJson
 module.exports.shareFixtures = shareFixtures
 module.exports.shareFeed = shareFeed
 module.exports.fileList = fileList
@@ -64,6 +65,14 @@ function matchDatLink (str) {
   return key
 }
 
+function datJson (filepath) {
+  try {
+    return JSON.parse(fs.readFileSync(path.join(filepath, 'dat.json')))
+  } catch (e) {
+    return {}
+  }
+}
+
 function isDir (dir) {
   try {
     return fs.statSync(dir).isDirectory()