// Code for benchmarking.

'use strict';

var async = require('async');
var syncbase = require('syncbase');
var nosql = syncbase.nosql;

var util = require('./util');

exports.logFn = logFn;
exports.runBenchmark = runBenchmark;

var LOG_EVERYTHING = false;

function logStart(name) {
  console.log(name + ' start');
  return Date.now();
}

function logStop(name, start) {
  console.log(name + ' took ' + (Date.now() - start) + 'ms');
}

function logFn(name, cb) {
  var start = logStart(name);
  return function() {
    logStop(name, start);
    cb.apply(null, arguments);
  };
}

// Does n parallel puts with a common prefix, then returns the prefix.
function doPuts(ctx, tb, n, cb) {
  cb = logFn('doPuts', cb);
  var prefix = util.timestamp() + '.';
  async.times(100, function(n, cb) {
    // TODO(sadovsky): Remove this once we loosen Syncbase's naming rules.
    prefix = prefix.replace(/:/g, '.');
    var key = prefix + n;
    var value = '';
    if (LOG_EVERYTHING) console.log('put: ' + key);
    tb.put(ctx, key, value, function(err) {
      if (LOG_EVERYTHING) console.log('put done: ' + key);
      cb(err);
    });
  }, function(err) {
    return cb(err, prefix);
  });
}

// Scans (and logs) all records with the given prefix.
function doScan(ctx, tb, prefix, cb) {
  cb = logFn('doScan(' + prefix + ')', cb);
  var bytes = 0, streamErr = null;
  tb.scan(ctx, nosql.rowrange.prefix(prefix), function(err) {
    err = err || streamErr;
    if (err) return cb(err);
    console.log('scanned ' + bytes + ' bytes');
    cb();
  }).on('data', function(row) {
    bytes += row.key.length + row.value.length;
    if (LOG_EVERYTHING) console.log('scan: ' + JSON.stringify(row));
  }).on('error', function(err) {
    streamErr = streamErr || err.error;
  });
}

// Assumes table 'tb' exists.
function runBenchmark(ctx, db, cb) {
  cb = logFn('runBenchmark', cb);
  var tb = db.table('tb');
  doPuts(ctx, tb, 100, function(err, prefix) {
    if (err) return cb(err);
    doScan(ctx, tb, prefix, cb);
  });
}