describe('HashRing', function () {
  "use strict";

  var Hashring = require('../')
    , assume = require('assume');

  it('exposes the library version', function () {
    assume(Hashring.version).matches(/^\d+\.\d+\.\d+$/);
  });

  it('libmemcached compatiblity', function () {
    var ring = new Hashring({
      '10.0.1.1:11211': 600,
      '10.0.1.2:11211': 300,
      '10.0.1.3:11211': 200,
      '10.0.1.4:11211': 350,
      '10.0.1.5:11211': 1000,
      '10.0.1.6:11211': 800,
      '10.0.1.7:11211': 950,
      '10.0.1.8:11211': 100
    });

    // VDEAAAAA hashes to fffcd1b5, after the last continuum point, and lets us
    // test the boundary wraparound.
    assume(ring.find(ring.hashValue('VDEAAAAA'))).equals(0);
  });

  describe('API', function () {
    it('constructs with a string', function () {
      var ring = new Hashring('192.168.0.102:11212');

      assume(ring.servers).has.length(1);
      assume(ring.ring.length).is.above(1);
    });

    it('constructs with a array', function () {
      var ring = new Hashring([
          '192.168.0.102:11212'
        , '192.168.0.103:11212'
        , '192.168.0.104:11212'
      ]);

      assume(ring.servers).has.length(3);
      assume(ring.ring.length).is.above(1);
    });

    it('constructs with a object', function () {
      var ring = new Hashring({
          '192.168.0.102:11212': 2
        , '192.168.0.103:11212': 2
        , '192.168.0.104:11212': 2
      });

      assume(ring.servers).has.length(3);
      assume(ring.ring.length).is.above(1);

      ring.servers.forEach(function (server) {
        assume(server.weight).is.above(1);
      });
    });

    it('constructs with a object with per node vnodes', function () {
      var ring = new Hashring({
          '192.168.0.102:11212': { 'vnodes': 40 }
        , '192.168.0.103:11212': { 'vnodes': 50 }
        , '192.168.0.104:11212': { 'vnodes': 5 }
      });

      assume(ring.servers).is.length(3);
      assume(ring.ring.length).equals((40 + 50 + 5) * ring.replicas);

      ring = new Hashring({
          '192.168.0.102:11212': { 'vnodes': 4 }
        , '192.168.0.103:11212': { 'vnodes': 3 }
        , '192.168.0.104:11212': { 'vnodes': 5 }
      });

      assume(ring.servers).has.length(3);
      assume(ring.ring.length).equals((4 + 3 + 5) * ring.replicas);
    });

    it('constructs with a default vnode value', function () {
      var ring = new Hashring([
          '192.168.0.102:11212'
        , '192.168.0.103:11212'
      ], 'md5', { 'vnode count': 60 });

      assume(ring.ring.length).equals(60 * ring.replicas * ring.servers.length);
    });

    it('constructs with no arguments', function () {
      var ring = new Hashring();

      assume(ring.servers).has.length(0);
      assume(ring.ring).has.length(0);
    });

    it('normalizes the replicas to 1', function () {
      var ring = new Hashring([
          '192.168.0.102:11212'
        , '192.168.0.103:11212'
      ], 'md5', { 'replicas': 0 });

      assume(ring.replicas).equals(1);
    });

    it('accepts different algorithms', function () {
      var ring = new Hashring('192.168.0.102:11212', 'sha1');

      assume(ring.servers).has.length(1);
      assume(ring.algorithm).equals('sha1');
      assume(ring.ring.length).is.above(1);
    });

    it('generates the correct amount of points', function () {
      var ring = new Hashring({
          '127.0.0.1:11211': 600
        , '127.0.0.1:11212': 400
      });

      assume(ring.ring.length).equals(160 * 2);
    });

    describe("#add", function () {
      it('adds server after zero-argument constructor', function () {
        var ring = new Hashring();
        ring.add('192.168.0.102:11212');

        assume(ring.servers).has.length(1);
        assume(ring.ring.length).is.above(1);
      });
    });

    describe('#get', function () {
      it('looks up keys', function () {
        var ring = new Hashring([
            '192.168.0.102:11212'
          , '192.168.0.103:11212'
          , '192.168.0.104:11212'
        ]);

        assume(ring.find(ring.hashValue('foo'))).is.above(-1);

        // NOTE we are going to do some flaky testing ;P
        assume(ring.get('foo')).equals('192.168.0.102:11212');
        assume(ring.get('pewpew')).equals('192.168.0.103:11212');

        // we are not gonna verify the results we are just gonna test if we don't
        // fuck something up in the code, so it throws errors or whatever

        // unicode keys, just because people roll like that
        assume(ring.find(ring.hashValue('привет мир, Memcached и nodejs для победы'))).is.above(-1);

        // other odd keys
        assume(ring.find(ring.hashValue(1))).is.above(-1);
        assume(ring.find(ring.hashValue(0))).is.above(-1);
        assume(ring.find(ring.hashValue([]))).is.above(-1);
        assume(ring.find(ring.hashValue({wtf:'lol'}))).is.above(-1);

        // this should work as both objects are converted to [object Object] by
        // the .toString() constructor
        assume(ring.get({wtf:'lol'})).equals(ring.get({wtf:'amazing .toStringing'}));
      });
    });

    describe('#hashValue', function () {
      it('should create the correct long value for a given key', function () {
        var ring = new Hashring({
            '127.0.0.1:11211': 600
          , '127.0.0.1:11212': 400
        });

        assume(ring.hashValue('test')).equals(3446378249);
      });
    });

    describe('#find', function () {
      it('should find the correct long value for a given key', function () {
        var ring = new Hashring({
            '127.0.0.1:11211': 600
          , '127.0.0.1:11212': 400
        });

        assume(ring.ring[ring.find(ring.hashValue('test'))].value).equals(3454255383);
      });
    });

    describe('#swap', function () {
      it('swaps servers', function () {
        var ring = new Hashring([
              '192.168.0.102:11212'
            , '192.168.0.103:11212'
            , '192.168.0.104:11212'
          ])
          , amazon = ring.get('justdied')
          , skynet = '192.168.0.128:11212';

        ring.swap(amazon, skynet);
        assume(ring.cache.get('justdied')).equals(skynet);

        // After a cleared cache, it should still resolve to the same server
        ring.cache.reset();
        assume(ring.get('justdied')).equals(skynet);
      });
    });

    describe('#remove', function () {
      it('removes servers', function () {
        var ring = new Hashring([
            '192.168.0.102:11212'
          , '192.168.0.103:11212'
          , '192.168.0.104:11212'
        ]);

        ring.remove('192.168.0.102:11212');
        ring.ring.forEach(function (node) {
          assume(node.server).does.not.equal('192.168.0.102:11212');
        });
      });

      it('Removes the last server', function () {
        var ring = new Hashring('192.168.0.102:11212');
        ring.remove('192.168.0.102:11212');

        assume(ring.servers).has.length(0);
        assume(ring.ring).has.length(0);
      });
    });

    describe('#has', function () {
      it('has a server', function () {
        var ring = new Hashring([
            '192.168.0.102:11212'
          , '192.168.0.103:11212'
          , '192.168.0.104:11212'
        ]);

        assume(ring.has('192.168.0.102:11212')).is.true();
      });

      it('does not have a server', function () {
        var ring = new Hashring([
            '192.168.0.102:11212'
          , '192.168.0.103:11212'
          , '192.168.0.104:11212'
        ]);

        assume(ring.has('192.168.0.105:11212')).is.false();
      });
    });

    describe('#range', function () {
      it('returns 20 servers', function () {
        var ring = new Hashring([
            '192.168.0.102:11212'
          , '192.168.0.103:11212'
          , '192.168.0.104:11212'
        ]);

        assume(ring.range('foo', 20, false)).is.length(20);
      });

      it('returns 3 servers as we only want unique servers', function () {
        var ring = new Hashring([
            '192.168.0.102:11212'
          , '192.168.0.103:11212'
          , '192.168.0.104:11212'
        ]);

        assume(ring.range('foo', 20, false)).is.length(20);
      });
    });
  });
});