bin/clone.js

@@ -44,5 +44,5 @@ function handleClone (args) {
    else console.error('Clone from remote to %s has completed.', path)
  })

  progress(cloneStream, {verb: 'Cloned', replicate: true})
  progress(cloneStream, {verb: 'Cloning', replicate: true})
}

bin/write.js

@@ -4,6 +4,7 @@ var debug = require('debug')('bin/write')
var openDat = require('../lib/util/open-dat.js')
var abort = require('../lib/util/abort.js')
var usage = require('../lib/util/usage.js')('write.txt')
var progress = require('../lib/util/progress.js')

module.exports = {
  name: 'write',
@@ -57,15 +58,17 @@ function handleWrite (args) {
      message: args.message
    }

    pump(inputStream, db.createFileWriteStream(key, opts), function done (err) {
    var writer = db.createFileWriteStream(key, opts)
    progress(writer, {bytes: true, verb: 'Storing ' + key})
    pump(inputStream, writer, function done (err) {
      if (err) abort(err, args, 'Error: Write failed')

      if (args.json) {
        var output = {
          version: db.head
        }
        console.log(JSON.stringify(output))
      } else console.error('Done writing binary data. \nVersion: ' + db.head)
      } else console.error('Stored ' + key + ' successfully. \nCurrent version is now: ' + db.head)

    })
  })

lib/util/progress.js

@@ -1,4 +1,5 @@
var log = require('single-line-log').stderr
var prettyBytes = require('pretty-bytes')

module.exports = function (stream, options) {
  setInterval(printProgress, 200).unref()
@@ -7,7 +8,9 @@ module.exports = function (stream, options) {
  stream.on('end', printProgress)

  function printProgress () {
    if (options.replicate) {
    if (options.bytes) {
      log(options.verb + ' (' + prettyBytes(stream.progress.bytes) + ').\n')
    } else if (options.replicate) {
      log(
        options.verb +
        ' [+' + stream.progress.puts + ', -' + stream.progress.deletes + ']' +