Mirroristas/gun
2
0
Fork 0
mirror of https://github.com/amark/gun.git synced 2025-06-07 06:36:46 +00:00
Code Issues Packages Projects Releases Wiki Activity

AXE - new test and example for webrtc.

Browse Source
This commit is contained in:
Adriano Rogowski 2019-01-22 22:55:36 -02:00
parent 803c5b6ee0
commit 7bc146bcce
3 changed files with 141 additions and 37 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
examples/axe.html
View File

@ -8,8 +8,11 @@
</head> </head>
<body> <body>
<h3 id="pid"></h3>
<script src="../gun.js"></script> <script src="../gun.js"></script>
<!-- <script src="../axe.js"></script> --> <script src="../gun/axe.js"></script>
<script src="../gun/lib/radix.js"></script>
<script src="../gun/lib/webrtc.js"></script>
<!-- <script src="../sea.js"></script> --> <!-- <script src="../sea.js"></script> -->
<script> <script>
var pid = location.hash.slice(1); var pid = location.hash.slice(1);
@ -23,14 +26,17 @@
Gun.on('opt', function(ctx) { Gun.on('opt', function(ctx) {
this.to.next(ctx); this.to.next(ctx);
ctx.on('hi', function(opt) { ctx.on('hi', function(opt) {
console.log('HI!! PEER', new Date(), opt.pid); // console.log('HI!! PEER', new Date(), opt.pid);
setTimeout(function() {
document.getElementById('pid').innerHTML = gun._.opt.pid;
});
}); });
if (pid) { // if (pid) {
ctx.on('out', function(msg) { // ctx.on('out', function(msg) {
msg.pid = pid; // msg.pid = pid;
this.to.next(msg); // this.to.next(msg);
}); // });
} // }
}); });
var gun = Gun(opt); var gun = Gun(opt);

150
test/axe/holy-grail.js
View File

@ -2,8 +2,8 @@
* AXE test 1 * AXE test 1
* What we want here: (1) Superpeer and (n) peers * What we want here: (1) Superpeer and (n) peers
* - The peers receives only the requested data. * - The peers receives only the requested data.
* - If the Superpeer crash, must recreate all subscriptions and update the peers. * - If the Superpeer crash, after restart, 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. * - If some peer crash or go offline, must receive the changes via RTC.
* *
* Tip: to run this `npm run testaxe` * 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 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`
@ -13,15 +13,16 @@ var config = {
IP: require('ip').address(), IP: require('ip').address(),
port: 8765, port: 8765,
servers: 2, servers: 2,
browsers: 2, browsers: 3,
route: { route: {
'/': __dirname + '/index.html', '/': __dirname + '/index.html',
'/gun.js': __dirname + '/../../gun.js', '/gun.js': __dirname + '/../../gun.js',
'/gun/axe.js': __dirname + '/../../axe.js', '/gun/axe.js': __dirname + '/../../axe.js',
'/gun/lib/radix.js': __dirname + '/../../lib/radix.js',
'/gun/lib/webrtc.js': __dirname + '/../../lib/webrtc.js',
'/jquery.js': __dirname + '/../../examples/jquery.js' '/jquery.js': __dirname + '/../../examples/jquery.js'
} }
} }
var panic = require('panic-server'); var panic = require('panic-server');
panic.server().on('request', function(req, res){ panic.server().on('request', function(req, res){
config.route[req.url] && require('fs').createReadStream(config.route[req.url]).pipe(res); config.route[req.url] && require('fs').createReadStream(config.route[req.url]).pipe(res);
@ -45,10 +46,10 @@ var server2 = servers.excluding(server).pluck(1);
var browsers = clients.excluding(servers); var browsers = clients.excluding(servers);
var alice = browsers.pluck(1); var alice = browsers.pluck(1);
var bob = browsers.excluding(alice).pluck(1); var bob = browsers.excluding(alice).pluck(1);
var john = browsers.excluding(alice).excluding(bob).pluck(1);
var again = {}; var again = {};
describe("The Holy Grail AXE Test!", function(){ describe("The Holy Grail AXE Test!", function(){
console.time('TOTAL TEST TIME');
this.timeout(5 * 60 * 1000); this.timeout(5 * 60 * 1000);
// this.timeout(10 * 60 * 1000); // this.timeout(10 * 60 * 1000);
@ -89,25 +90,35 @@ describe("The Holy Grail AXE Test!", function(){
tests.push(client.run(function(test){ tests.push(client.run(function(test){
localStorage.clear(); console.log('Clear localStorage!!!'); localStorage.clear(); console.log('Clear localStorage!!!');
var env = test.props; var env = test.props;
var gun = window.gun = Gun({peers:['http://'+ env.config.IP + ':' + (env.config.port + 1) + '/gun'], wait: 1000}); var opt = {peers:['http://'+ env.config.IP + ':' + (env.config.port + 1) + '/gun'], wait: 1000};
var pid = location.hash.slice(1);
if (pid) { opt.pid = pid; }
Gun.on('opt', function(ctx) {
this.to.next(ctx);
ctx.on('hi', function(opt) {
document.getElementById('pid').innerHTML = (document.getElementById('pid').innerHTML || "-") + ', ' + this.on.opt.pid;
});
});
var gun = window.gun = Gun(opt);
window.ref = gun.get('holy').get('grail'); window.ref = gun.get('holy').get('grail');
}, {i: i += 1, config: config})); }, {i: i += 1, config: config}));
}); });
return Promise.all(tests); return Promise.all(tests);
}); });
it("Wait for Alice and Bob...", function(done){ it("Wait for Alice, Bob and John...", function(done){
setTimeout(done, 1000); setTimeout(done, 1000);
}); });
it("Alice Write: Hi Bob!", function(){ it("Alice Write: Hi Bob!", function(){
return alice.run(function(test){ return alice.run(function(test){
console.log("I AM ALICE"); console.log("I AM ALICE");
$('#name').text('Alice');
test.async(); 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.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) { ref.put('Hi Bob!', function(ack) {
console.log(ack); console.log(ack);
setTimeout(test.done, 10000); setTimeout(test.done, 2000);
}); });
}); });
}); });
@ -116,6 +127,7 @@ describe("The Holy Grail AXE Test!", function(){
it("Bob receive ONCE from Alice: Hi Bob!", function(){ it("Bob receive ONCE from Alice: Hi Bob!", function(){
return bob.run(function(test){ return bob.run(function(test){
console.log("I AM BOB"); console.log("I AM BOB");
$('#name').text('Bob');
test.async(); test.async();
ref.once(function(data){ ref.once(function(data){
if('Hi Bob!' === data){ if('Hi Bob!' === data){
@ -157,10 +169,29 @@ describe("The Holy Grail AXE Test!", function(){
}) })
}); });
it("Jhon Read what Bob say to Alice: Hi Alice!", function(){
return john.run(function(test){
test.async();
console.log("I AM JOHN");
$('#name').text('John');
ref.once(function(data){
if('Hi Alice!' === data){
console.log('[OK] John receive the data: ', data);
return test.done();
} else {
//TODO: aqui em duvida.. está pegando do localStorage, mas Bob alterou o dado.
var err = '[FAIL] John receive wrong data: "' + data + '" and must be "Hi Alice!"';
console.log(err);
return test.fail(err);
}
})
})
});
it("Bob Write in some data, Alice not subscribed", function(){ it("Bob Write in some data, Alice not subscribed", function(){
return bob.run(function(test){ return bob.run(function(test){
test.async(); test.async();
gun.get('bob').get('mine').put('Alice dont want this data!', function() { gun.get('bob').get('mine').put('Alice dont want this data now!', function() {
setTimeout(test.done, 2000); setTimeout(test.done, 2000);
}); });
}); });
@ -172,13 +203,17 @@ describe("The Holy Grail AXE Test!", function(){
/// This must be empty, because alice don't make a subscription to this node. /// This must be empty, because alice don't make a subscription to this node.
var bobdata = JSON.parse(localStorage.getItem('gun/')).bob; var bobdata = JSON.parse(localStorage.getItem('gun/')).bob;
if (bobdata) { if (bobdata) {
var err = '[FAIL] Alice receive not subscribed data: ' + JSON.stringify(bobdata); var err = '[FAIL] Alice receive not subscribed data in localStorage: ' + JSON.stringify(bobdata);
console.log(err); console.log(err);
return test.fail(err); return test.fail(err);
} else {
console.log('[OK] Alice Read must NOT receive data from Bob: ', bobdata);
return test.done();
} }
if (gun._.graph.bob) {
var err = '[FAIL] Alice receive not subscribed data in in graph: ' + JSON.stringify(gun._.graph.bob);
console.log(err);
return test.fail(err);
}
console.log('[OK] Alice Read must NOT receive data from Bob: ', bobdata);
return test.done();
}) })
}); });
@ -202,12 +237,12 @@ describe("The Holy Grail AXE Test!", function(){
return bob.run(function(test){ return bob.run(function(test){
test.async(); test.async();
gun.get('bob').get('mine').put('Alice WANT this data now!', function() { gun.get('bob').get('mine').put('Alice WANT this data now!', function() {
setTimeout(test.done, 2000); setTimeout(test.done, 5000);
}); });
}); });
}); });
it("Alice must receive updates from Bob node", function(){ it("Alice must receive 'Alice WANT this data now!' from Bob node", function(){
return alice.run(function(test){ return alice.run(function(test){
test.async(); test.async();
if (gun._.graph.bob && gun._.graph.bob.mine === 'Alice WANT this data now!') { if (gun._.graph.bob && gun._.graph.bob.mine === 'Alice WANT this data now!') {
@ -223,7 +258,6 @@ describe("The Holy Grail AXE Test!", function(){
it("Server has crashed!", function(){ it("Server has crashed!", function(){
return server.run(function(test){ return server.run(function(test){
console.log(3);
// var env = test.props; // var env = test.props;
// try{ require('fs').unlinkSync(env.i+'data'); }catch(e){} // try{ require('fs').unlinkSync(env.i+'data'); }catch(e){}
process.exit(0); process.exit(0);
@ -231,11 +265,10 @@ describe("The Holy Grail AXE Test!", function(){
}); });
it("Wait...", function(done){ it("Wait...", function(done){
console.log(4);
setTimeout(done, 2000); setTimeout(done, 2000);
}); });
it("Alice update the data (superpeer crashed yet).", function(){ it("Alice change the data (superpeer crashed yet).", function(){
return alice.run(function(test){ return alice.run(function(test){
var env = test.props; var env = test.props;
if(window.WebSocket){ if(window.WebSocket){
@ -247,17 +280,17 @@ describe("The Holy Grail AXE Test!", function(){
} }
test.async() test.async()
ref.put("Superpeer? Where are you?", function() { ref.put("Superpeer? Where are you?", function() {
setTimeout(test.done, 100); setTimeout(test.done, 1000);
}); });
}, {config: config}); }, {config: config});
}); });
it("Bob can't see what Alice change because Superpeer is out.", function(){ it("Bob receive what Alice change via WebRTC.", function(){
return bob.run(function(test){ return bob.run(function(test){
test.async(); test.async();
ref.once(function(data){ ref.once(function(data){
if('Superpeer? Where are you?' !== data){ if('Superpeer? Where are you?' === data){
console.log('[OK] Bob have old data: ', data); console.log('[OK] Bob received data via WebRTC: ', data);
return test.done(); return test.done();
} else { } else {
var err = '[FAIL] Bob MUST not receive: "Superpeer? Where are you?", but receive: ' + data; var err = '[FAIL] Bob MUST not receive: "Superpeer? Where are you?", but receive: ' + data;
@ -268,6 +301,39 @@ describe("The Holy Grail AXE Test!", function(){
}) })
}); });
it("Bob change the data again (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("Alice, can you hear me?", function() {
setTimeout(test.done, 1000);
});
}, {config: config});
});
it("Alice MUST receive 'Alice, can you hear me?' via WebRTC.", function(){
return bob.run(function(test){
test.async();
ref.once(function(data){
if('Alice, can you hear me?' === data){
console.log('[OK] Alice received data via WebRTC: ', data);
return test.done();
} else {
var err = '[FAIL] Alice MUST not receive: "Superpeer? Where are you?", but receive: ' + data;
console.log(err);
return test.fail(err);
}
})
})
});
it("Superpeer come started again!", function(){ it("Superpeer come started again!", function(){
return server2.run(function(test){ return server2.run(function(test){
var env = test.props; var env = test.props;
@ -291,19 +357,28 @@ describe("The Holy Grail AXE Test!", function(){
}); });
it("Wait sync...", function(done){ it("Wait sync...", function(done){
console.log(4);
setTimeout(done, 5000); setTimeout(done, 5000);
}); });
it("Bob now receive what Alice change because Superpeer is on.", function(){ it("Alice change the data again (superpeer is UP!).", function(){
return alice.run(function(test){
var env = test.props;
test.async()
ref.put("Yes Bob! Thanks for asking!", function() {
setTimeout(test.done, 1000);
});
}, {config: config});
});
it("Bob MUST receive 'Yes Bob! Thanks for asking!'", function(){
return bob.run(function(test){ return bob.run(function(test){
test.async(); test.async();
ref.once(function(data){ ref.once(function(data){
if('Superpeer? Where are you?' === data){ if('Yes Bob! Thanks for asking!' === data){
console.log('[OK] Bob have old data: ', data); console.log('[OK] Bob received the data change: ', data);
return test.done(); return test.done();
} else { } else {
var err = '[FAIL] Bob MUST not receive: "Superpeer? Where are you?", but receive: ' + data; var err = '[FAIL] Bob MUST not receive: "Yes Bob! Thanks for asking!", but receive: ' + data;
console.log(err); console.log(err);
return test.fail(err); return test.fail(err);
} }
@ -311,6 +386,26 @@ describe("The Holy Grail AXE Test!", function(){
}) })
}); });
it("John dont want to know what Bob say in his node!", function(){
return john.run(function(test){
test.async();
/// This must be empty, because John don't make a subscription to this node.
var bobdata = JSON.parse(localStorage.getItem('gun/')).bob;
if (bobdata) {
var err = '[FAIL] John receive not subscribed data: ' + JSON.stringify(bobdata);
console.log(err);
return test.fail(err);
}
if (gun._.graph.bob) {
var err = '[FAIL] John receive not subscribed data in in graph: ' + JSON.stringify(gun._.graph.bob);
console.log(err);
return test.fail(err);
}
console.log('[OK] John Read must NOT receive data from Bob: ', bobdata, gun._.graph.bob);
return test.done();
})
});
it("All finished!", function(done){ it("All finished!", function(done){
console.log("Done! Cleaning things up..."); console.log("Done! Cleaning things up...");
setTimeout(function(){ setTimeout(function(){
@ -326,6 +421,5 @@ describe("The Holy Grail AXE Test!", function(){
return servers.run(function(){ return servers.run(function(){
process.exit(); process.exit();
}); });
console.timeEnd('TOTAL TEST TIME');
}); });
}); });

6
test/axe/index.html
View File

@ -2,8 +2,12 @@
<script>panic.server(location.origin)</script> <script>panic.server(location.origin)</script>
<script src='gun.js'></script> <script src='gun.js'></script>
<script src='gun/axe.js'></script> <script src='gun/axe.js'></script>
<script src="gun/lib/radix.js"></script>
<script src='gun/lib/webrtc.js'></script>
<script src='jquery.js'></script> <script src='jquery.js'></script>
<meta charset="utf-8"/> <meta charset="utf-8"/>
<h1>Running AXE Tests.</h1> <h1>Running AXE Tests</h1>
<div><span>Name: </span><span id="name"></span></div>
<div><span>PID: </span><span id="pid"></span></div>
<div id="log"></div> <div id="log"></div>
<!-- <textarea id="print" style="width: 100%; height: 90%; border: 0;"></textarea> --> <!-- <textarea id="print" style="width: 100%; height: 90%; border: 0;"></textarea> -->