View
362 lib/commands.js

Large diffs are not rendered by default.

Oops, something went wrong.
View
91 lib/parse-cli.js

This file was deleted.

Oops, something went wrong.
View
47 lib/progress-log.js
@@ -0,0 +1,47 @@
// TODO: rewrite this insanity
var speedometer = require('speedometer')
var clearLog = require('single-line-log')
var pretty = require('pretty-bytes')
var eos = require('end-of-stream')
module.exports = function(prog, verb, end) {
verb = verb || 'Transferred'
verb += ' '.slice(verb.length)
var start = Date.now()
var count = 0
var elapsed = 0
var speed = speedometer()
var lastBytes = 0
var pad = function(str) {
if (str.length < 9) return str+' '.slice(str.length)
return str
}
var draw = function() {
var stats = prog.stats || prog
speed(stats.bytes - lastBytes)
lastBytes = stats.bytes
var runtime = Math.floor((Date.now() - start) / 1000)
clearLog(
'Elapsed : '+runtime+' s\n'+
verb+': '+pad(pretty(stats.bytes || 0)) +' ('+pretty(speed())+'/s)'+ '\n'+
(stats.changes >= 0 ? ' - changes : '+stats.changes+'\n' : '')+
(stats.blobs >= 0 ? ' - blobs : '+stats.blobs+'\n' : '')
)
}
var interval = setInterval(draw, 250)
draw()
eos(prog, function(err) {
draw()
clearInterval(interval)
if (err) clearLog.clear()
else if (end) console.log(end)
})
}
View
2 test/tests/init.js
@@ -60,7 +60,7 @@ module.exports.existingRepo = function(test, common) {
module.exports.existingRepoClone = function(test, common) {
test('.clone in existing repo should return error', function(t) {
var dat = new Dat(common.dat1tmp, function ready() {
dat.clone({remote:"http://localhost", quiet:true}, function(err) {
dat.clone('http://localhost', {quiet:true}, function(err) {
t.true(err, err)
dat.destroy(function(err) {
t.false(err, 'no err')
View
8 test/tests/replication.js
@@ -221,7 +221,7 @@ module.exports.pushReplication = function(test, common) {
function putPushCompare(doc, cb) {
dat.put(doc, function(err, doc) {
if (err) throw err
dat.push({remote: 'http://localhost:' + dat2port, quiet: true}, function(err) {
dat.push('http://localhost:' + dat2port, { quiet: true}, function(err) {
if (err) throw err
common.compareData(t, dat, dat2, function() {
cb()
@@ -271,7 +271,7 @@ module.exports.pushReplicationURLNormalize = function(test, common) {
function putPushCompare(doc, cb) {
dat.put(doc, function(err, doc) {
if (err) throw err
dat.push({remote: 'localhost:' + dat2port, quiet: true}, function(err) {
dat.push('localhost:' + dat2port, { quiet: true}, function(err) {
if (err) throw err
common.compareData(t, dat, dat2, function() {
cb()
@@ -303,7 +303,7 @@ module.exports.remoteClone = function(test, common) {
if (err) throw err
var dat2 = new Dat(common.dat2tmp, { init: false }, function ready() {
var remote = 'http://localhost:' + dat.options.port
dat2.clone({ remote: remote, quiet: true }, function(err) {
dat2.clone(remote, { quiet: true }, function(err) {
t.notOk(err, 'no err on clone')
verify(dat2)
})
@@ -337,7 +337,7 @@ module.exports.skimClone = function(test, common) {
t.notOk(err, 'no blob write err')
var dat2 = new Dat(common.dat2tmp, { init: false }, function ready() {
var remote = 'http://localhost:' + dat.options.port
dat2.clone({ remote: remote, path: common.dat2tmp, quiet: true, skim: true }, function(err) {
dat2.clone(remote, { path: common.dat2tmp, quiet: true, skim: true }, function(err) {
t.notOk(err, 'no err on clone')
verify(dat2)
})