cli.js

#!/usr/bin/env node

var path = require('path')
var minimist = require('minimist')
var pretty = require('prettier-bytes')
var speed = require('speedometer')
var progress = require('progress-string')
var cliTruncate = require('cli-truncate')
var neatLog = require('neat-log')
var mirror = require('mirror-folder')
var debug = require('debug')('dat-next')
var view = require('./ui')

var Dat = require('./')

process.title = 'dat-next'

var argv = minimist(process.argv.slice(2), {
  alias: {temp: 't', help: 'h', watch: 'w', sleep: 's'},
  boolean: ['watch'],
  default: {
    // 'watch' : true
  }
})

var src = argv._[0] || process.cwd()
var dest = argv._[1]
var logspeed = argv.logspeed || 400
var quiet = debug.enabled || !!process.env.DEBUG

if (!argv._.length || argv.help) return usage()

runDat()

function runDat () {
  Dat(src, dest, argv, function (err, dat) {
    if (err) {
      console.error('ERROR:', err)
      process.exit(1)
    }

    var network = dat.joinNetwork()

    if (dat.owner) share()
    else {
      network.once('connection', function () {
        console.log('connected to peer!')
        dat.archive.db.source.on('sync', function () {
          console.log('Downloaded')
        })
      })
    }


    function share () {
      network.on('connection', function () {
        console.log('new connection')
      })
      console.log('Sharing', path.resolve(src))

      var progress = dat.importFiles(src, {
        ignore: ['node_modules', '.dat']
      }, function (err) {
        if (err) throw err
        console.log('Done importing')
      })
      progress.on('put', function (src, dest) {
        console.log('Added', dest.name)
      })

      console.log(`KEY: ${dat.key.toString('hex')}\n`)
    }
  })
}

function usage () {
  console.error('dat-next!')
  console.error('  dat-next <dir>         SHARE directory')
  console.error('  dat-next <key> <dir>   DOWNLOAD key to dir (directory required)')
  process.exit(0)
}