// 'use strict'

// const assert   = require('assert')
// const path     = require('path')
// const fs       = require('fs')
// const Promise  = require('bluebird')
// const rimraf   = require('rimraf')
// const IpfsApis = require('ipfs-test-apis')
// const IpfsDaemon = require('ipfs-daemon')
// const OrbitDB  = require('../src/OrbitDB')

// const username  = 'testrunner'
// const username2 = 'rennurtset'
// const cacheFile = path.join(process.cwd(), '/tmp/orbit-db-tests/cache.json')

// IpfsApis.forEach(function(ipfsApi) {
//   let ipfs, ipfsDaemon

//   describe('CounterStore with ' + ipfsApi.name, function() {
//     this.timeout(40000)
//     let client1, client2
//     let daemon1, daemon2

//     before((done) => {
//       // rimraf.sync('./orbit-db-cache.json')
//       daemon1
//       Promise.all([
//         IpfsDaemon({ IpfsDataDir: '/tmp/daemon1' }), 
//         IpfsDaemon({ IpfsDataDir: '/tmp/daemon2' })
//       ])
//       .then((res) => {
//         ipfs = [res[0].ipfs, res[1].ipfs]
//         daemon1 = res[0].daemon
//         daemon2 = res[1].daemon
//         done()        
//       })     
//     })

//     after((done) => {
//       daemon1.stopDaemon()
//       daemon2.stopDaemon()
//       done()
//     })

//     beforeEach(() => {
//       client1 = new OrbitDB(ipfs[0], username, { cacheFile: cacheFile })
//       client2 = new OrbitDB(ipfs[1], username2, { cacheFile: cacheFile })
//     })

//     afterEach(() => {
//       if(client1) client1.disconnect()
//       if(client2) client2.disconnect()
//     })

//     describe('counters', function() {
//       it('increases a counter value', function(done) {
//         const timeout = setTimeout(() => done(new Error('event was not fired')), 2000)
//         const counter = client1.counter('counter test', { subscribe: false, cacheFile: cacheFile })
//         counter.events.on('ready', () => {
//           Promise.map([13, 1], (f) => counter.inc(f), { concurrency: 1 })
//             .then(() => {
//               assert.equal(counter.value(), 14)
//               clearTimeout(timeout)
//               client1.disconnect()
//               done()
//             })
//             .catch(done)
//         })
//       })

//       it('creates a new counter from cached data', function(done) {
//         const timeout = setTimeout(() => done(new Error('event was not fired')), 2000)
//         const counter = client1.counter('counter test', { subscribe: false, cacheFile: cacheFile })
//         counter.events.on('ready', () => {
//           assert.equal(counter.value(), 14)
//           clearTimeout(timeout)
//           client1.disconnect()
//           done()
//         })
//       })

//       it.only('syncs counters', (done) => {
//         const name = new Date().getTime()
//         const counter1 = client1.counter(name)
//         const counter2 = client2.counter(name)
//         const numbers = [[13, 10], [2, 5]]
//         // const res1 = ([13, 10]).map((f) => counter1.inc(f))//, { concurrency: 1 })
//         // const res2 = ([2, 5]).map((f) => counter2.inc(f))//, { concurrency: 1 })
//         Promise.map([counter1, counter2], (counter, i) => numbers[i].map((e) => counter.inc(e)) , { concurrency: 1 })
//           .then((res) => {
//             // wait for a while to make sure db's have been synced
//             setTimeout(() => {
//               assert.equal(counter2.value(), 30)
//               assert.equal(counter1.value(), 30)
//               done()
//             }, 10000)
//           })
//           .catch(done)
//       })

//     })
//   })

// })