/*!
 * ws: a node.js websocket client
 * Copyright(c) 2011 Einar Otto Stangvik <einaros@gmail.com>
 * MIT Licensed
 */

/**
 * Benchmark dependencies.
 */

var benchmark = require('benchmark')
  , Receiver = require('../').Receiver
  , Sender = require('../').Sender
  , suite = new benchmark.Suite('Receiver');
require('tinycolor');
require('./util');

/**
 * Setup receiver.
 */
 
suite.on('start', function () {
  receiver = new Receiver();
  sender = new Sender();
});

suite.on('cycle', function () {
  receiver = new Receiver();
  sender = new Sender();
});

/**
 * Benchmarks.
 */

var pingMessage = 'Hello'
  , pingPacket1 = getBufferFromHexString('89 ' + (pack(2, 0x80 | pingMessage.length)) + 
                                         ' 34 83 a8 68 '+ getHexStringFromBuffer(mask(pingMessage, '34 83 a8 68')));
suite.add('ping message', function () {
  receiver.add(pingPacket1);  
});

var pingPacket2 = getBufferFromHexString('89 00')
suite.add('ping with no data', function () {
  receiver.add(pingPacket2);
});

var closePacket = getBufferFromHexString('88 00');
suite.add('close message', function () {
  receiver.add(closePacket);
  receiver.endPacket();
});

var maskedTextPacket = getBufferFromHexString('81 93 34 83 a8 68 01 b9 92 52 4f a1 c6 09 59 e6 8a 52 16 e6 cb 00 5b a1 d5');
suite.add('masked text message', function () {
  receiver.add(maskedTextPacket);
});

binaryDataPacket = (function() {
  var length = 125
    , message = new Buffer(length)
  for (var i = 0; i < length; ++i) message[i] = i % 10;
  return getBufferFromHexString('82 ' + getHybiLengthAsHexString(length, true) + ' 34 83 a8 68 '
       + getHexStringFromBuffer(mask(message), '34 83 a8 68'));
})();
suite.add('binary data (125 bytes)', function () {
  try {
    receiver.add(binaryDataPacket);
    
  }
  catch(e) {console.log(e)}
});

binaryDataPacket2 = (function() {
  var length = 65535
    , message = new Buffer(length)
  for (var i = 0; i < length; ++i) message[i] = i % 10;
  return getBufferFromHexString('82 ' + getHybiLengthAsHexString(length, true) + ' 34 83 a8 68 '
       + getHexStringFromBuffer(mask(message), '34 83 a8 68'));
})();
suite.add('binary data (65535 bytes)', function () {
  receiver.add(binaryDataPacket2);
});

binaryDataPacket3 = (function() {
  var length = 200*1024
    , message = new Buffer(length)
  for (var i = 0; i < length; ++i) message[i] = i % 10;
  return getBufferFromHexString('82 ' + getHybiLengthAsHexString(length, true) + ' 34 83 a8 68 '
       + getHexStringFromBuffer(mask(message), '34 83 a8 68'));
})();
suite.add('binary data (200 kB)', function () {
  receiver.add(binaryDataPacket3);
});

framePacket = new Buffer(200*1024);
framePacket.fill(99);
suite.add('frameData, unmasked (200 kB)', function () {
  sender.frameData(0x2, framePacket, true, false);
});
suite.add('frameData, masked (200 kB)', function () {
  sender.frameData(0x2, framePacket, true, true);
});

/**
 * Output progress.
 */

suite.on('cycle', function (bench, details) {
  console.log('\n  ' + suite.name.grey, details.name.white.bold);
  console.log('  ' + [
      details.hz.toFixed(2).cyan + ' ops/sec'.grey
    , details.count.toString().white + ' times executed'.grey
    , 'benchmark took '.grey + details.times.elapsed.toString().white + ' sec.'.grey
    , 
  ].join(', '.grey));
});

/**
 * Run/export benchmarks.
 */

if (!module.parent) {
  suite.run();
} else {
  module.exports = suite;
}