'use strict';

const assert      = require('assert');
const Promise     = require('bluebird');
const rimraf      = require('rimraf')
const ipfsd       = require('ipfsd-ctl');
const OrbitClient = require('../src/Client');
const OrbitServer = require('orbit-server/src/server');

// Mute logging
require('logplease').setLogLevel('ERROR');

const username  = 'testrunner';
const username2 = 'rennurtset';

const ipfsPath = '/tmp/orbittests';

const startIpfs = () => {
  return new Promise((resolve, reject) => {
    // ipfsd.local(ipfsPath, (err, node) => {
    //   if(err) reject(err);
    //   node.startDaemon((err, ipfs) => {
    //     if(err) reject(err);
    //     resolve(ipfs);
    //   });
    // });
    OrbitServer.start();
    ipfsd.disposableApi((err, ipfs) => {
      if(err) reject(err);
      resolve(ipfs);
    });
  });
};

describe('CounterStore', function() {
  this.timeout(20000);

  let ipfs, client1, client2;

  before((done) => {
    rimraf.sync('./orbit-db-cache.json')
    startIpfs().then((res) => {
      ipfs = res;
      Promise.map([username, username2], (login) => {
        return OrbitClient.connect('localhost', 3333, login, '', ipfs, { allowOffline: false, cacheFile: './orbit-db-cache.json' });
      }).then((clients) => {
        client1 = clients[0];
        client2 = clients[1];
        done();
      }).catch((e) => {
        console.log(e.stack);
        assert.equal(e, null);
      });
    });
  });

  after((done) => {
    if(client1) client1.disconnect();
    if(client2) client2.disconnect();
    rimraf('./orbit-db-cache.json', done)
  });

  describe('counters', function() {
    it('increases a counter value', (done) => {
      client1.counter('counter test', false).then((counter) => {
        Promise.map([13, 1], (f) => counter.inc(f), { concurrency: 1 }).then(() => {
          assert.equal(counter.value(), 14);
          done();
        }).catch((e) => {
          console.error(e.stack);
          assert.equal(null, e);
          done();
        });
      }).catch((e) => {
        console.error(e.stack);
        assert.equal(' ', e.message);
        done();
      });
    });

    it('creates a new counter from cached data', function(done) {
      client1.counter('counter test', false).then((counter) => {
        assert.equal(counter.value(), 14);
        done();
      }).catch((e) => {
        console.error(e.stack);
        assert.equal(' ', e.message);
        done();
      });
    });

    it('syncs counters', (done) => {
      const name = new Date().getTime();
      Promise.all([client1.counter(name), client2.counter(name)]).then((counters) => {
      // Promise.all([client1.counter(name)]).then((counters) => {
        const res1 = Promise.map([13, 10], (f) => counters[0].inc(f), { concurrency: 1 });
        const res2 = Promise.map([2, 5], (f) => counters[1].inc(f), { concurrency: 1 })
        Promise.all([res1, res2]).then((res) => {
          setTimeout(() => {
            assert.equal(counters[0].value(), 30);
            assert.equal(counters[1].value(), 30);
            done();
          }, 1000)
        }).catch((e) => {
          console.log(e);
          assert(e);
          done();
        });
      }).catch((e) => {
        console.log(e);
        assert(e);
        done();
      });
    });

  });

});