mirror of
https://github.com/orbitdb/orbitdb.git
synced 2025-10-07 22:57:07 +00:00
Run tests with js-ipfs and local daemon
This commit is contained in:
haad
1100
test/client.test.js
1100
test/client.test.js
File diff suppressed because it is too large
Load Diff
@@ -5,126 +5,137 @@ const path = require('path');
|
||||
const fs = require('fs');
|
||||
const Promise = require('bluebird');
|
||||
const rimraf = require('rimraf')
|
||||
// const ipfsd = require('ipfsd-ctl');
|
||||
const OrbitDB = require('../src/OrbitDB');
|
||||
const OrbitServer = require('orbit-server/src/server');
|
||||
const IPFS = require('ipfs')
|
||||
const ipfsd = require('ipfsd-ctl');
|
||||
const IPFS = require('ipfs')
|
||||
|
||||
// Mute logging
|
||||
require('logplease').setLogLevel('ERROR');
|
||||
|
||||
const network = 'Qmeh6ktQ1YFKksugJb59vBxG51xXoEvjBZXRK3DdrF3mNj';
|
||||
const network = 'Qmeh6ktQ1YFKksugJb59vBxG51xXoEvjBZXRK3DdrF3mNj';
|
||||
const username = 'testrunner';
|
||||
const username2 = 'rennurtset';
|
||||
const ipfsPath = '/tmp/orbittests';
|
||||
|
||||
const ipfsPath = '/tmp/orbittests';
|
||||
|
||||
const startIpfs = () => {
|
||||
return new Promise((resolve, reject) => {
|
||||
OrbitServer.start();
|
||||
// ipfsd.disposableApi((err, ipfs) => {
|
||||
// if(err) reject(err);
|
||||
// resolve(ipfs);
|
||||
// });
|
||||
// ipfsd.local(ipfsPath, (err, node) => {
|
||||
// if(err) reject(err);
|
||||
// node.startDaemon((err, ipfs) => {
|
||||
// if(err) reject(err);
|
||||
// resolve(ipfs);
|
||||
// });
|
||||
// });
|
||||
const ipfs = new IPFS();
|
||||
ipfs.goOnline(() => {
|
||||
resolve(ipfs)
|
||||
})
|
||||
});
|
||||
};
|
||||
|
||||
describe('CounterStore', function() {
|
||||
this.timeout(20000);
|
||||
|
||||
let ipfs, client1, client2;
|
||||
|
||||
before((done) => {
|
||||
rimraf.sync('./orbit-db-cache.json')
|
||||
startIpfs()
|
||||
// .then((ipfs) => {
|
||||
// return ipfs.add(path.resolve(process.cwd(), './test/network.json')).then(() => ipfs)
|
||||
// })
|
||||
.then((res) => {
|
||||
ipfs = res;
|
||||
return Promise.map([username, username2], (login) => {
|
||||
return OrbitDB.connect(network, login, '', ipfs, { allowOffline: false, cacheFile: './orbit-db-cache.json' });
|
||||
}).then((clients) => {
|
||||
client1 = clients[0];
|
||||
client2 = clients[1];
|
||||
return;
|
||||
}).catch((e) => {
|
||||
console.log(e.stack);
|
||||
assert.equal(e, null);
|
||||
let ipfs, ipfsDaemon;
|
||||
const IpfsApis = [{
|
||||
// js-ipfs
|
||||
start: () => {
|
||||
return new Promise((resolve, reject) => {
|
||||
const IPFS = require('ipfs')
|
||||
const ipfs = new IPFS();
|
||||
ipfs.goOnline(() => resolve(ipfs));
|
||||
});
|
||||
},
|
||||
stop: () => new Promise((resolve, reject) => ipfs.goOffline(resolve))
|
||||
}, {
|
||||
// js-ipfs-api via local daemon
|
||||
start: () => {
|
||||
return new Promise((resolve, reject) => {
|
||||
ipfsd.local((err, node) => {
|
||||
if(err) reject(err);
|
||||
ipfsDaemon = node;
|
||||
ipfsDaemon.startDaemon((err, ipfs) => {
|
||||
if(err) reject(err);
|
||||
resolve(ipfs);
|
||||
});
|
||||
})
|
||||
.then(done)
|
||||
});
|
||||
});
|
||||
});
|
||||
},
|
||||
stop: () => new Promise((resolve, reject) => ipfsDaemon.stopDaemon(resolve))
|
||||
}];
|
||||
|
||||
after((done) => {
|
||||
if(client1) client1.disconnect();
|
||||
if(client2) client2.disconnect();
|
||||
rimraf('./orbit-db-cache.json', done)
|
||||
});
|
||||
// OrbitServer.start(); // uncomment if running this test suite stand-alone
|
||||
IpfsApis.forEach(function(ipfsApi) {
|
||||
|
||||
describe('counters', function() {
|
||||
it('increases a counter value', (done) => {
|
||||
client1.counter('counter test', { subscribe: false, cacheFile: './orbit-db-cache.json' }).then((counter) => {
|
||||
Promise.map([13, 1], (f) => counter.inc(f), { concurrency: 1 }).then(() => {
|
||||
describe('CounterStore', function() {
|
||||
this.timeout(40000);
|
||||
let client1, client2;
|
||||
|
||||
before((done) => {
|
||||
rimraf.sync('./orbit-db-cache.json')
|
||||
ipfsApi.start()
|
||||
// .then((ipfs) => {
|
||||
// return ipfs.add(path.resolve(process.cwd(), './test/network.json')).then(() => ipfs)
|
||||
// })
|
||||
.then((res) => {
|
||||
ipfs = res;
|
||||
return Promise.map([username, username2], (login) => {
|
||||
return OrbitDB.connect(network, login, '', ipfs, { allowOffline: false, cacheFile: './orbit-db-cache.json' });
|
||||
}).then((clients) => {
|
||||
client1 = clients[0];
|
||||
client2 = clients[1];
|
||||
return;
|
||||
}).catch((e) => {
|
||||
console.log(e.stack);
|
||||
assert.equal(e, null);
|
||||
});
|
||||
})
|
||||
.then(done)
|
||||
});
|
||||
|
||||
after((done) => {
|
||||
if(client1) client1.disconnect();
|
||||
if(client2) client2.disconnect();
|
||||
ipfsApi.stop().then(() => {
|
||||
rimraf('./orbit-db-cache.json', done)
|
||||
});
|
||||
});
|
||||
|
||||
describe('counters', function() {
|
||||
it('increases a counter value', (done) => {
|
||||
client1.counter('counter test', { subscribe: false, cacheFile: './orbit-db-cache.json' }).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', { subscribe: false, cacheFile: './orbit-db-cache.json' }).then((counter) => {
|
||||
assert.equal(counter.value(), 14);
|
||||
done();
|
||||
}).catch((e) => {
|
||||
console.error(e.stack);
|
||||
assert.equal(null, e);
|
||||
assert.equal(' ', e.message);
|
||||
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', { subscribe: false, cacheFile: './orbit-db-cache.json' }).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) => {
|
||||
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);
|
||||
it('syncs counters', (done) => {
|
||||
const name = new Date().getTime();
|
||||
Promise.all([client1.counter(name), client2.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();
|
||||
}, 1000)
|
||||
});
|
||||
}).catch((e) => {
|
||||
console.log(e);
|
||||
assert(e);
|
||||
done();
|
||||
});
|
||||
}).catch((e) => {
|
||||
console.log(e);
|
||||
assert(e);
|
||||
done();
|
||||
});
|
||||
});
|
||||
|
||||
});
|
||||
});
|
||||
|
||||
});
|
||||
|
||||
Reference in New Issue
Block a user