mirror of
https://github.com/amark/gun.git
synced 2025-05-21 22:36:43 +00:00
332 lines
9.4 KiB
JavaScript
332 lines
9.4 KiB
JavaScript
/**
|
|
* AXE test 1
|
|
* What we want here: (1) Superpeer and (n) peers
|
|
* - The peers receives only the requested data.
|
|
* - If the Superpeer crash, must recreate all subscriptions and update the peers.
|
|
* - If some peer crash or go offline, when connected again must receive the changes made by others while out.
|
|
*
|
|
* Tip: to run this `npm run testaxe`
|
|
* Tip 2: if you clone the gun repo, you need to create a link do gun package. Do `npm install && cd node_modules && ln -s ../ gun`
|
|
* Tip 3: If you not in localhost, run the browsers in anonymous mode because of domain security policies. https://superuser.com/questions/565409/how-to-stop-an-automatic-redirect-from-http-to-https-in-chrome
|
|
*/
|
|
var config = {
|
|
IP: require('ip').address(),
|
|
port: 8765,
|
|
servers: 2,
|
|
browsers: 2,
|
|
route: {
|
|
'/': __dirname + '/index.html',
|
|
'/gun.js': __dirname + '/../../gun.js',
|
|
'/gun/axe.js': __dirname + '/../../axe.js',
|
|
'/jquery.js': __dirname + '/../../examples/jquery.js'
|
|
}
|
|
}
|
|
|
|
var panic = require('panic-server');
|
|
panic.server().on('request', function(req, res){
|
|
config.route[req.url] && require('fs').createReadStream(config.route[req.url]).pipe(res);
|
|
}).listen(config.port);
|
|
|
|
var clients = panic.clients;
|
|
var manager = require('panic-manager')();
|
|
manager.start({
|
|
clients: Array(config.servers).fill().map(function(u, i){
|
|
return {
|
|
type: 'node',
|
|
port: config.port + (i + 1)
|
|
}
|
|
}),
|
|
panic: 'http://' + config.IP + ':' + config.port
|
|
});
|
|
|
|
var servers = clients.filter('Node.js');
|
|
var server = servers.pluck(1);
|
|
var server2 = servers.excluding(server).pluck(1);
|
|
var browsers = clients.excluding(servers);
|
|
var alice = browsers.pluck(1);
|
|
var bob = browsers.excluding(alice).pluck(1);
|
|
var again = {};
|
|
|
|
describe("The Holy Grail AXE Test!", function(){
|
|
console.time('TOTAL TEST TIME');
|
|
this.timeout(5 * 60 * 1000);
|
|
// this.timeout(10 * 60 * 1000);
|
|
|
|
it("Servers have joined!", function(){
|
|
return servers.atLeast(config.servers);
|
|
});
|
|
|
|
it("GUN started!", function(){
|
|
return server.run(function(test){
|
|
var env = test.props;
|
|
test.async();
|
|
try{ require('fs').unlinkSync(env.i+'dataaxe') }catch(e){}
|
|
try{ require('fs').unlinkSync((env.i+1)+'dataaxe') }catch(e){}
|
|
var port = env.config.port + env.i;
|
|
var server = require('http').createServer(function(req, res){
|
|
res.end("I am "+ env.i +"!");
|
|
});
|
|
var Gun = require('gun');
|
|
require('gun/axe');
|
|
var gun = Gun({
|
|
file: env.i+'dataaxe',
|
|
web: server
|
|
});
|
|
server.listen(port, function(){
|
|
test.done();
|
|
});
|
|
}, {i: 1, config: config});
|
|
});
|
|
|
|
it(config.browsers +" browser(s) have joined!", function(){
|
|
console.log("PLEASE OPEN http://"+ config.IP +":"+ config.port +" IN "+ config.browsers +" BROWSER(S)!");
|
|
return browsers.atLeast(config.browsers);
|
|
});
|
|
|
|
it("Browsers initialized gun!", function(){
|
|
var tests = [], i = 0;
|
|
browsers.each(function(client, id){
|
|
tests.push(client.run(function(test){
|
|
localStorage.clear(); console.log('Clear localStorage!!!');
|
|
var env = test.props;
|
|
var gun = window.gun = Gun({peers:['http://'+ env.config.IP + ':' + (env.config.port + 1) + '/gun'], wait: 1000});
|
|
window.ref = gun.get('holy').get('grail');
|
|
}, {i: i += 1, config: config}));
|
|
});
|
|
return Promise.all(tests);
|
|
});
|
|
|
|
it("Wait for Alice and Bob...", function(done){
|
|
setTimeout(done, 1000);
|
|
});
|
|
|
|
it("Alice Write: Hi Bob!", function(){
|
|
return alice.run(function(test){
|
|
console.log("I AM ALICE");
|
|
test.async();
|
|
ref.once(function() { // TODO: Need `.once` first for subscription. If Alice do a `.put` before a `.once`, Alice will get old data from localStorage if Bob update
|
|
ref.put('Hi Bob!', function(ack) {
|
|
console.log(ack);
|
|
setTimeout(test.done, 10000);
|
|
});
|
|
});
|
|
});
|
|
});
|
|
|
|
it("Bob receive ONCE from Alice: Hi Bob!", function(){
|
|
return bob.run(function(test){
|
|
console.log("I AM BOB");
|
|
test.async();
|
|
ref.once(function(data){
|
|
if('Hi Bob!' === data){
|
|
console.log('[OK] Bob receive the question: ', data);
|
|
return test.done();
|
|
} else {
|
|
var err = '[FAIL] Bob MUST receive: Hi Bob! but receive: ' + data + ' Storage: ' + localStorage.getItem('gun/');
|
|
console.log(err);
|
|
return test.fail(err);
|
|
}
|
|
})
|
|
})
|
|
});
|
|
|
|
it("Bob Write response: Hi Alice!", function(){
|
|
return bob.run(function(test){
|
|
test.async();
|
|
ref.put('Hi Alice!', function(ack) {
|
|
console.log('[OK] Bob Write response: Hi Alice!', ack);
|
|
setTimeout(test.done, 2000);
|
|
});
|
|
});
|
|
});
|
|
|
|
it("Alice Read response from Bob: Hi Alice!", function(){
|
|
return alice.run(function(test){
|
|
test.async();
|
|
ref.once(function(data){
|
|
if('Hi Alice!' === data){
|
|
console.log('[OK] Alice receive the response: ', data);
|
|
return test.done();
|
|
} else {
|
|
//TODO: aqui em duvida.. está pegando do localStorage, mas Bob alterou o dado.
|
|
var err = '[FAIL] Alice receive wrong response: "' + data + '" and must be "Hi Alice!"';
|
|
console.log(err);
|
|
return test.fail(err);
|
|
}
|
|
})
|
|
})
|
|
});
|
|
|
|
it("Bob Write in some data, Alice not subscribed", function(){
|
|
return bob.run(function(test){
|
|
test.async();
|
|
gun.get('bob').get('mine').put('Alice dont want this data!', function() {
|
|
setTimeout(test.done, 2000);
|
|
});
|
|
});
|
|
});
|
|
|
|
it("Alice not subscribed. Must NOT receive data from Bob", function(){
|
|
return alice.run(function(test){
|
|
test.async();
|
|
/// This must be empty, because alice don't make a subscription to this node.
|
|
var bobdata = JSON.parse(localStorage.getItem('gun/')).bob;
|
|
if (bobdata) {
|
|
var err = '[FAIL] Alice receive not subscribed data: ' + JSON.stringify(bobdata);
|
|
console.log(err);
|
|
return test.fail(err);
|
|
} else {
|
|
console.log('[OK] Alice Read must NOT receive data from Bob: ', bobdata);
|
|
return test.done();
|
|
}
|
|
})
|
|
});
|
|
|
|
it("Alice subscription Bob data with ONCE, MUST receive", function(){
|
|
return alice.run(function(test){
|
|
test.async();
|
|
gun.get('bob').once(function(data){
|
|
if(data){
|
|
console.log('[OK] Alice receive the value: ', data);
|
|
return test.done();
|
|
} else {
|
|
var err = '[FAIL] Alice receive the value: ' + data;
|
|
console.log(err);
|
|
return test.fail(err);
|
|
}
|
|
})
|
|
})
|
|
});
|
|
|
|
it("Bob Write in some data. Now Alice is subscribed.", function(){
|
|
return bob.run(function(test){
|
|
test.async();
|
|
gun.get('bob').get('mine').put('Alice WANT this data now!', function() {
|
|
setTimeout(test.done, 2000);
|
|
});
|
|
});
|
|
});
|
|
|
|
it("Alice must receive updates from Bob node", function(){
|
|
return alice.run(function(test){
|
|
test.async();
|
|
if (gun._.graph.bob && gun._.graph.bob.mine === 'Alice WANT this data now!') {
|
|
console.log('[OK] GRAPH: ', gun._.graph.bob);
|
|
test.done();
|
|
} else {
|
|
var err = '[FAIL] GRAPH: ' + JSON.stringify(gun._.graph.bob);
|
|
console.log(err);
|
|
test.fail(err);
|
|
}
|
|
})
|
|
});
|
|
|
|
it("Server has crashed!", function(){
|
|
return server.run(function(test){
|
|
console.log(3);
|
|
// var env = test.props;
|
|
// try{ require('fs').unlinkSync(env.i+'data'); }catch(e){}
|
|
process.exit(0);
|
|
}, {i: 1, config: config})
|
|
});
|
|
|
|
it("Wait...", function(done){
|
|
console.log(4);
|
|
setTimeout(done, 2000);
|
|
});
|
|
|
|
it("Alice update the data (superpeer crashed yet).", function(){
|
|
return alice.run(function(test){
|
|
var env = test.props;
|
|
if(window.WebSocket){
|
|
var err;
|
|
try{ new WebSocket('http://'+ env.config.IP + ':' + (env.config.port + 2) + '/gun') }catch(e){ err = e }
|
|
if(!err){
|
|
test.fail("Server did not crash.");
|
|
}
|
|
}
|
|
test.async()
|
|
ref.put("Superpeer? Where are you?", function() {
|
|
setTimeout(test.done, 100);
|
|
});
|
|
}, {config: config});
|
|
});
|
|
|
|
it("Bob can't see what Alice change because Superpeer is out.", function(){
|
|
return bob.run(function(test){
|
|
test.async();
|
|
ref.once(function(data){
|
|
if('Superpeer? Where are you?' !== data){
|
|
console.log('[OK] Bob have old data: ', data);
|
|
return test.done();
|
|
} else {
|
|
var err = '[FAIL] Bob MUST not receive: "Superpeer? Where are you?", but receive: ' + data;
|
|
console.log(err);
|
|
return test.fail(err);
|
|
}
|
|
})
|
|
})
|
|
});
|
|
|
|
it("Superpeer come started again!", function(){
|
|
return server2.run(function(test){
|
|
var env = test.props;
|
|
test.async();
|
|
// try{ require('fs').unlinkSync(env.i+'dataaxe') }catch(e){}
|
|
// try{ require('fs').unlinkSync((env.i+1)+'dataaxe') }catch(e){}
|
|
var port = env.config.port + env.i;
|
|
var server = require('http').createServer(function(req, res){
|
|
res.end("I am "+ env.i +"!");
|
|
});
|
|
var Gun = require('gun');
|
|
require('gun/axe');
|
|
var gun = Gun({
|
|
file: env.i+'dataaxe',
|
|
web: server
|
|
});
|
|
server.listen(port, function(){
|
|
test.done();
|
|
});
|
|
}, {i: 1, config: config});
|
|
});
|
|
|
|
it("Wait sync...", function(done){
|
|
console.log(4);
|
|
setTimeout(done, 5000);
|
|
});
|
|
|
|
it("Bob now receive what Alice change because Superpeer is on.", function(){
|
|
return bob.run(function(test){
|
|
test.async();
|
|
ref.once(function(data){
|
|
if('Superpeer? Where are you?' === data){
|
|
console.log('[OK] Bob have old data: ', data);
|
|
return test.done();
|
|
} else {
|
|
var err = '[FAIL] Bob MUST not receive: "Superpeer? Where are you?", but receive: ' + data;
|
|
console.log(err);
|
|
return test.fail(err);
|
|
}
|
|
})
|
|
})
|
|
});
|
|
|
|
it("All finished!", function(done){
|
|
console.log("Done! Cleaning things up...");
|
|
setTimeout(function(){
|
|
done();
|
|
},1000);
|
|
});
|
|
after("Everything shut down.", function(){
|
|
browsers.run(function(){
|
|
//location.reload();
|
|
//setTimeout(function(){
|
|
//}, 15 * 1000);
|
|
});
|
|
return servers.run(function(){
|
|
process.exit();
|
|
});
|
|
console.timeEnd('TOTAL TEST TIME');
|
|
});
|
|
});
|