Mirroristas/gun
2
0
Fork 0
mirror of https://github.com/amark/gun.git synced 2025-03-30 15:08:33 +00:00
Code Issues Packages Projects Releases Wiki Activity
gun/test/common.js
Dimitris Apostolou 9e616ea3a9
Fix typos (#1299)
2023-02-25 17:09:54 -08:00

8429 lines
232 KiB
JavaScript
Raw Permalink Blame History

describe('Gun', function(){
var root;
(function(){
var env;
if(typeof global !== 'undefined'){ env = global }
if(typeof window !== 'undefined'){ env = window }
root = env.window? env.window : global;
try{ env.window && root.localStorage && root.localStorage.clear() }catch(e){}
try{ localStorage.clear() }catch(e){}
try{ require('fs').unlinkSync('data.json') }catch(e){}
try{ require('../lib/fsrm')('radatatest') }catch(e){}
//root.Gun = root.Gun || require('../gun');
if(root.Gun){
root.Gun = root.Gun;
root.Gun.TESTING = true;
} else {
require('../lib/yson');
root.Gun = require('../gun');
root.Gun.TESTING = true;
require('../lib/store');
require('../lib/rfs');
//console.log("UNDO THIS SO RAD & SEA RUN!");
require('./rad/rad.js');
require('./sea/sea.js');
}
}(this));
//Gun.log.squelch = true;
var gleak = {globals: {}, check: function(){ // via tobyho
var leaked = []
for (var key in gleak.globe){ if (!(key in gleak.globals)){ leaked.push(key)} }
if (leaked.length > 0){ console.log("GLOBAL LEAK!", leaked); return leaked }
}};
(function(env){
for (var key in (gleak.globe = env)){ gleak.globals[key] = true }
}(this));
var t = {};
describe('Utility', function(){
it('deleting old GUN tests (may take long time)', function(done){
done(); // Mocha doesn't print test until after its done, so show this first.
});
it('deleted', function(done){
this.timeout(60 * 1000);
if(!Gun.window){ return done() }
indexedDB.deleteDatabase('radatatest').onsuccess = function(e){ done() }
});
var u;
/* // causes logger to no longer log.
it('verbose console.log debugging', function(done) {
var gun = Gun();
var log = root.console.log, counter = 1;
root.console.log = function(a,b,c){
--counter;
//log(a,b,c);
}
Gun.log.verbose = true;
gun.put('bar', function(err, yay){ // intentionally trigger an error that will get logged.
expect(counter).to.be(0);
Gun.log.verbose = false;
gun.put('bar', function(err, yay){ // intentionally trigger an error that will get logged.
expect(counter).to.be(0);
root.console.log = log;
done();
});
});
} );
*/
describe('YSON', function(){
it('parse', function(){
//var json = require('fs').readFileSync('./radix.json').toString();
//var json = require('fs').readFileSync('./data.json').toString();
//var json = require('fs').readFileSync('./big.json').toString();
//var json = require('fs').readFileSync('./stats.json').toString();
//var json = require('fs').readFileSync('./video.json').toString();
});
it('backslash', function(done){
var o = {z:"test\"wow\\"};
JSON.stringifyAsync(o, function(err,t){
JSON.parseAsync(t, function(err,data){
expect(data).to.be.eql(o);
next();
})
});
function next(){
JSON.parseAsync('{"webRTCsdp":"v=0\r\no=-"}', function(err,data){
var o = {webRTCsdp: 'v=0\r\no=-'};
expect(data).to.be.eql(o);
JSON.stringifyAsync(o, function(err,t){
expect(JSON.parse(t)).to.be.eql(o);
expect(t).to.be(JSON.stringify(o));
expect(t).to.be('{"webRTCsdp":"v=0\\r\\no=-"}');
JSON.parseAsync(t, function(err,d){
expect(d).to.be.eql(o);
done();
})
});
})
}
});
it('stringify', function(done){
function Foo(){}; Foo.prototype.toJSON = function(){};
//var obj = {"what\"lol": {"a": 1, "b": true, "c": false, "d": null, "wow": [{"z": 9}, true, "hi", 3.3]}};
var obj = {"what": {"a": 1, "b": true, "c": false, "d": null, "wow": [{"z": 9}, true, "hi", 3.3]}};
var obj = [{x:"test 😎\\😄🔥",z:"test\\","what\"lol": {"0": 1.01},a:true,b: new Foo,c:3,y:"yes","get":{"#":"chat"},wow:undefined,foo:[1,function(){}, function(){}, 'go'],blah:{a:5,toJSON:function(){ return 9 }}}, {webRTCsdp: "v=0\r\no=-"}, [[]], 10e9, NaN];
JSON.stringifyAsync(obj, function(err, text){
JSON.parseAsync(text, function(err, data){
expect(data).to.be.eql([{x:"test 😎\\😄🔥",z:"test\\","what\"lol": {"0": 1.01},a:true,c:3,y:"yes","get":{"#":"chat"},foo:[1,null,null,'go'],blah:9}, {webRTCsdp: "v=0\r\no=-"}, [[]], 10e9, null]);
var obj = {a: [], b: [""], c: ["", 1], d: [1, ""], e: {"":[]}, "a\"b": {0: 1}, wow: {'': {cool: 1}}};obj.lol = {0: {sweet: 9}};obj.wat = {"": 'cool'};obj.oh = {phew: {}, "": {}};
JSON.stringifyAsync(obj, function(err, text2){
JSON.parseAsync(text2, function(err, data){
expect(data).to.be.eql(obj);
done();
})
})
})
});
});
});
describe('Type Check', function(){
it('random text',function(){
expect(String.random().length).to.be(24);
expect(String.random(11).length).to.be(11);
expect(String.random(4).length).to.be(4);
t.tr = String.random(2,'as'); expect((t.tr=='as'||t.tr=='aa'||t.tr=='sa'||t.tr=='ss')).to.be.ok();
});
it('match text',function(){
expect(String.match("user/mark", 'user/mark')).to.be.ok();
expect(String.match("user/mark/nadal", {'=': 'user/mark'})).to.not.be.ok();
expect(String.match("user/mark/nadal", {'*': 'user/'})).to.be.ok();
expect(String.match("email/mark@gunDB.io", {'*': 'user/'})).to.not.be.ok();
expect(String.match("user/mark/nadal", {'>': 'user/j', '<': 'user/o'})).to.be.ok();
expect(String.match("user/timber/nadal", {'>': 'user/c', '<': 'user/j'})).to.not.be.ok();
expect(String.match("user/timber/nadal", {'>': 'user/m', '<': 'user/u'})).to.be.ok();
expect(String.match("user/mark/nadal", {'>': 'user/a', '<': 'user/c'})).to.not.be.ok();
expect(String.match("mary", {'<': 'm'})).to.not.be.ok();
expect(String.match("mary", {'>': 'm'})).to.be.ok();
expect(String.match("m", {'>': 'm'})).to.be.ok(); // lex is inclusive because it evaluates stricter (=) to looser (>) comparisons, see docs.
expect(String.match("m", {'<': 'm'})).to.be.ok(); // lex is inclusive because it evaluates stricter (=) to looser (<) comparisons, see docs.
return; // below is OLD bloat, still available in lib/match.js
});
it('plain object',function(){
expect(Object.plain({})).to.be(true);
expect(Object.plain({a:1})).to.be(true);
expect(Object.plain(u)).to.be(false);
expect(Object.plain()).to.be(false);
expect(Object.plain(undefined)).to.be(false);
expect(Object.plain(null)).to.be(false);
expect(Object.plain(NaN)).to.be(false);
expect(Object.plain(0)).to.be(false);
expect(Object.plain(1)).to.be(false);
expect(Object.plain('')).to.be(false);
expect(Object.plain('a')).to.be(false);
expect(Object.plain([])).to.be(false);
expect(Object.plain([1])).to.be(false);
expect(Object.plain(false)).to.be(false);
expect(Object.plain(true)).to.be(false);
expect(Object.plain(function(){})).to.be(false);
expect(Object.plain(new Date())).to.be(false);
expect(Object.plain(/regex/)).to.be(false);
this.document && expect(Object.plain(document.createElement('div'))).to.be(false);
expect(Object.plain(new (function Class(){ this.x = 1; this.y = 2 })())).to.be(true);
});
it('empty',function(){
expect(Object.empty()).to.be(true);
expect(Object.empty({a:false})).to.be(false);
expect(Object.empty({a:false},['a'])).to.be(true);
expect(Object.empty({a:false},['a'])).to.be(true);
expect(Object.empty({a:false,b:1},['a'])).to.be(false);
expect(Object.empty({a:false,b:1},['a'])).to.be(false);
expect(Object.empty({a:false,b:1},['a','b'])).to.be(true);
expect(Object.empty({a:false,b:1,c:3},['a','b'])).to.be(false);
expect(Object.empty({1:1},'danger')).to.be(false);
});
});
describe('Functions', function(){
/*
it.skip('sum',function(done){ // deprecate?
var obj = {a:2, b:2, c:3, d: 9};
Gun.obj.map(obj, function(num, key){
setTimeout(this.add(function(){
this.done(null, num * num);
}, key), parseInt((""+Math.random()).substring(2,5)));
}, Gun.fn.sum(function(err, val){
expect(val.a).to.eql(4);
expect(val.b).to.eql(4);
expect(val.c).to.eql(9);
expect(val.d).to.eql(81);
done();
}));
});
*/
});
describe('On', function(){
it('subscribe', function(done){
var e = {on: Gun.on};
e.on('foo', function(a){
done.first = true;
expect(a).to.be(1);
this.to.next(a);
});
e.on('foo', function(a){
expect(a).to.be(1);
expect(done.first).to.be.ok();
done();
});
e.on('foo', 1);
});
it('unsubscribe', function(done){
var e = {on: Gun.on};
e.on('foo', function(a){
this.off();
done.first = a;
expect(a).to.be(1);
this.to.next(a);
});
e.on('foo', function(a){
var to = this;
expect(a).to.be(done.second? 2 : 1);
expect(done.first).to.be(1);
done.second = true;
if(a === 2){
setTimeout(function(){
expect(e.tag.foo.to === to).to.be.ok();
done();
}, 10);
}
});
e.on('foo', 1);
e.on('foo', 2);
});
it('stun', function(done){
var e = {on: Gun.on};
e.on('foo', function(a, ev){
if(2 === a){
done.first2 = true;
this.to.next(a);
return;
}
setTimeout(function(){
expect(done.second).to.not.be.ok();
expect(done.second2).to.be.ok();
expect(done.first2).to.be.ok();
done();
},10);
});
e.on('foo', function(a, ev){
if(2 === a){
done.second2 = true;
} else {
done.second = true;
}
});
e.on('foo', 1);
e.on('foo', 2);
});
it('resume', function(done){
var e = {on: Gun.on};
e.on('foo', function(a, ev){
var to = this.to;
setTimeout(function(){
expect(done.second).to.not.be.ok();
to.next(a);
},10);
});
e.on('foo', function(a){
done.second = true;
expect(a).to.be(1);
done();
});
e.on('foo', 1);
});
it('double resume', function(done){
var e = {on: Gun.on};
e.on('foo', function(a, ev){
var to = this.to;
setTimeout(function(){
if(1 === a){
done.first1 = true;
expect(done.second).to.not.be.ok();
}
if(2 === a){
done.first2 = true;
}
to.next(a);
},10);
});
e.on('foo', function(a, ev){
done.second = true;
if(1 === a){
expect(done.first2).to.not.be.ok();
done.second1 = true;
}
if(2 === a){
expect(done.first2).to.be.ok();
if(done.second1){
done();
}
}
});
e.on('foo', 1);
e.on('foo', 2);
});
it('double resume different event', function(done){
var e = {on: Gun.on};
e.on('foo', function(a, ev){
var to = this.to;
setTimeout(function(){
done.first1 = true;
to.next(a);
},10);
});
e.on('foo', function(a){
if(1 === a){
expect(done.first1).to.be.ok();
done();
}
});
e.on('foo', 1);
e.on('bar', 2);
});
it('resume params', function(done){
var e = {on: Gun.on};
e.on('foo', function(a, ev){
var to = this.to;
setTimeout(function(){
expect(done.second).to.not.be.ok();
to.next(0);
},10);
});
e.on('foo', function(a){
done.second = true;
expect(a).to.be(0);
done();
});
e.on('foo', 1);
});
it('map', function(done){
var e = {on: Gun.on};
e.on('foo', function(a, ev){
var to = this.to;
Object.keys(a.it).forEach(function(f){var v = a.it[f];
setTimeout(function(){
var emit = {field: 'where', soul: f};
to.next(emit);
},10);
})
});
e.on('foo', function(a, ev){
var to = this.to;
setTimeout(function(){
to.next({node: a.soul});
},100);
});
e.on('foo', function(a){
if('a' == a.node){
done.a = true;
} else {
expect(done.a).to.be.ok();
done();
}
});
e.on('foo', {field: 'where', it: {a: 1, b: 2}});
});
it('map synchronous', function(done){
var e = {on: Gun.on};
e.on('foo', function(a, ev){
var to = this.to;
Object.keys(a.node).forEach(function(f){var v = a.node[f];
//setTimeout(function(){
var emit = {field: 'where', soul: f};
to.next(emit);
//},10);
})
});
e.on('foo', function(a, ev){
var to = this.to;
setTimeout(function(){
to.next({node: a.soul});
},100);
});
e.on('foo', function(a){
expect(this.as.hi).to.be(1);
if('a' == a.node){
done.a = true;
} else {
expect(done.a).to.be.ok();
done();
}
}, {hi: 1}).on.on('foo', {field: 'where', node: {a: 1, b: 2}});
});
it('synchronous async', function(done){
var e = {on: Gun.on};
e.on('foo', function(a){
expect(a.b).to.be(5);
done.first = true;
this.to.next(a);
});
e.on('foo', function(a, ev){
expect(a.b).to.be(5);
done.second = true;
var to = this.to;
setTimeout(function(){
to.next({c: 9, again: a.again});
},100);
});
e.on('foo', function(a){
this.off();
expect(a.again).to.not.be.ok();
expect(a.c).to.be(9);
expect(done.first).to.be.ok();
expect(done.second).to.be.ok();
done();
}).on.on('foo', {b: 5}).on.on('foo', {b:5, again: true});
});
});
describe('flow', function(){
var i = 0;
function flow(){
var f = function(arg){
var cb = f.cb? f.cb.fn : f.fn;
if(cb){
f.cb = cb;
var ff = flow();
ff.f = f;
cb(ff);
return;
}
if(f.f){
f.f(arg);
f.cb = 0;
return;
}
}, cb;
f.flow = function(fn){
cb = (cb || f).fn = fn;
return f;
};
return f;
}
it('intermittent interruption', function(done){
var f = flow();
//var f = {flow: flow}
f.flow(function(f){
//console.log(1);
f.flow(function(f){
//console.log(2);
f({yes: 'please'});
});
setTimeout(function(){
f.flow(function(f){
//console.log(2.1);
f({forever: 'there'});
});
f({strange: 'places'});
//console.log("-----");
f({earlier: 'location'});
},100);
});
f.flow(function(f){
//console.log(3);
f({ok: 'now'});
});
f.flow(function(f){
//console.log(4);
done();
});
setTimeout(function(){
f({hello: 'world'});
}, 100);
});
var i = 0;
;(function(exports){
function next(arg){ var n = this;
if(arg instanceof Function){
if(!n.fn){ return n.fn = arg, n }
var f = {next: next, fn: arg, first: n.first || n};
n.last = (n.last || n).to = f;
return n;
}
if(n.fn){
var sub = {next: next, from: n.to || (n.first || {}).from};
n.fn(sub);
return;
}
if(n.from){
n.from.next(arg);
return;
}
}
exports.next = next;
}(Gun));
it('intermittent interruptions', function(done){
//var f = flow();
var f = {next: Gun.next}; // for now
f.next(function(f){
//console.log(1, f);
f.next(function(f){
//console.log(2, f);
f.next({yes: 'please'});
});
setTimeout(function(){
f.next(function(f){
//console.log(2.1, f);
f.next({forever: 'there'});
});
f.next({strange: 'places'});
//console.log("-----");
f.next({earlier: 'location'});
},100);
});
f.next(function(f){
//console.log(3);
f.next({ok: 'now'});
});
f.next(function(f){
//console.log(4);
if(!done.a){ return done.a = true }
done();
});
setTimeout(function(){
f.next({hello: 'world'});
}, 100);
});
});
describe('Gun Safety', function(){
/* WARNING NOTE: Internal API has significant breaking changes! */
var gun = Gun();
it('is',function(){
expect(Gun.is(gun)).to.be(true);
expect(Gun.is(true)).to.be(false);
expect(Gun.is(false)).to.be(false);
expect(Gun.is(0)).to.be(false);
expect(Gun.is(1)).to.be(false);
expect(Gun.is('')).to.be(false);
expect(Gun.is('a')).to.be(false);
expect(Gun.is(Infinity)).to.be(false);
expect(Gun.is(-Infinity)).to.be(false);
expect(Gun.is(NaN)).to.be(false);
expect(Gun.is([])).to.be(false);
expect(Gun.is([1])).to.be(false);
expect(Gun.is({})).to.be(false);
expect(Gun.is({a:1})).to.be(false);
expect(Gun.is(function(){})).to.be(false);
});
it('valid',function(){
expect(Gun.valid(false)).to.be(true);
expect(Gun.valid(true)).to.be(true);
expect(Gun.valid(0)).to.be(true);
expect(Gun.valid(1)).to.be(true);
expect(Gun.valid('')).to.be(true);
expect(Gun.valid('a')).to.be(true);
expect(Gun.valid({'#':'somesoulidhere'})).to.be('somesoulidhere');
expect(Gun.valid({'#':'somesoulidhere', and: 'nope'})).to.be(false);
expect(Gun.valid(Infinity)).to.be(false); // boohoo :(
expect(Gun.valid(-Infinity)).to.be(false); // boohoo :(
expect(Gun.valid(NaN)).to.be(false);
expect(Gun.valid([])).to.be(false);
expect(Gun.valid([1])).to.be(false);
expect(Gun.valid({})).to.be(false);
expect(Gun.valid({a:1})).to.be(false);
expect(Gun.valid(function(){})).to.be(false);
});
it('is link',function(){
expect(Gun.valid({'#':'somesoulidhere'})).to.be('somesoulidhere');
expect(Gun.valid({'#':'somethingelsehere'})).to.be('somethingelsehere');
expect('string' == typeof Gun.valid({'#':'somesoulidhere', and: 'nope'})).to.be(false);
expect('string' == typeof Gun.valid({or: 'nope', '#':'somesoulidhere'})).to.be(false);
expect('string' == typeof Gun.valid(false)).to.be(false);
expect('string' == typeof Gun.valid(true)).to.be(false);
expect('string' == typeof Gun.valid('')).to.be(false);
expect('string' == typeof Gun.valid('a')).to.be(false);
expect('string' == typeof Gun.valid(0)).to.be(false);
expect('string' == typeof Gun.valid(1)).to.be(false);
expect('string' == typeof Gun.valid(Infinity)).to.be(false); // boohoo :(
expect('string' == typeof Gun.valid(-Infinity)).to.be(false); // boohoo :(
expect('string' == typeof Gun.valid(NaN)).to.be(false);
expect('string' == typeof Gun.valid([])).to.be(false);
expect('string' == typeof Gun.valid([1])).to.be(false);
expect('string' == typeof Gun.valid({})).to.be(false);
expect('string' == typeof Gun.valid({a:1})).to.be(false);
expect('string' == typeof Gun.valid(function(){})).to.be(false);
});
it.skip('is lex',function(){
expect(Gun.is.lex({'#': 'soul'})).to.eql({soul: 'soul'});
expect(Gun.is.lex({'.': 'field'})).to.eql({field: 'field'});
expect(Gun.is.lex({'=': 'value'})).to.eql({value: 'value'});
expect(Gun.is.lex({'>': 'state'})).to.eql({state: 'state'});
expect(Gun.is.lex({'#': {'=': 'soul'}})).to.eql({soul: {'=': 'soul'}});
expect(Gun.is.lex({'#': {'=': 'soul'}, '.': []})).to.be(false);
expect(Gun.is.lex({'#': {'=': 'soul'}, 'asdf': 'oye'})).to.be(false);
expect(Gun.is.lex()).to.be(false);
expect(Gun.is.lex('')).to.be(false);
});
it.skip('is lex ify',function(){
expect(Gun.is.lex.ify({'#': 'soul', '.': 'field', soul: 'foo', field: 'field', state: 0})).to.eql({'#': 'soul', '.': 'field', '>': 0});
});
});
});
describe('ify', function(){
console.log("TODO: BUG! Upgrade IFY tests to new internal API!");
return;
var test, gun = Gun();
it('null', function(done){
Gun.ify(null, function(err, ctx){
expect(err).to.be.ok();
done();
});
});
it('basic', function(done){
var data = {a: false, b: true, c: 0, d: 1, e: '', f: 'g', h: null};
Gun.ify(data, function(err, ctx){
expect(err).to.not.be.ok();
expect(ctx.err).to.not.be.ok();
expect(ctx.root).to.eql(data);
expect(ctx.root === data).to.not.ok();
done();
}, {pure: true});
});
it('basic soul', function(done){
var data = {_: {'#': 'SOUL'}, a: false, b: true, c: 0, d: 1, e: '', f: 'g', h: null};
Gun.ify(data, function(err, ctx){
expect(err).to.not.be.ok();
expect(ctx.err).to.not.be.ok();
expect(ctx.root).to.eql(data);
expect(ctx.root === data).to.not.be.ok();
expect(Gun.node.soul(ctx.root) === Gun.node.soul(data));
done();
}, {pure: true});
});
it('arrays', function(done){
var data = {before: {path: 'kill'}, one: {two: {lol: 'troll', three: [9, 8, 7, 6, 5]}}};
Gun.ify(data, function(err, ctx){
expect(err).to.be.ok();
expect((err.err || err).indexOf("one.two.three")).to.not.be(-1);
done();
});
});
it('undefined', function(done){
var data = {z: undefined, x: 'bye'};
Gun.ify(data, function(err, ctx){
expect(err).to.be.ok();
done();
});
});
it('NaN', function(done){
var data = {a: NaN, b: 2};
Gun.ify(data, function(err, ctx){
expect(err).to.be.ok();
done();
});
});
it('Infinity', function(done){ // SAD DAY PANDA BEAR :( :( :(... Mark wants Infinity. JSON won't allow.
var data = {a: 1, b: Infinity};
Gun.ify(data, function(err, ctx){
expect(err).to.be.ok();
done();
});
});
it('function', function(done){
var data = {c: function(){}, d: 'hi'};
Gun.ify(data, function(err, ctx){
expect(err).to.be.ok();
done();
});
});
it('extraneous', function(done){
var data = {_: {'#': 'shhh', meta: {yay: 1}}, sneak: true};
Gun.ify(data, function(err, ctx){
expect(err).to.not.be.ok(); // extraneous metadata needs to be stored, but it can't be used for data.
done();
});
});
it('document', function(done){
var data = {users: {1: {where: {lat: Math.random(), lng: Math.random(), i: 1}}}};
Gun.ify(data, function(err, ctx){
var soul, node;
expect(soul = Gun.val.link.is(ctx.root.users)).to.be.ok();
node = ctx.graph[soul];
expect(soul = Gun.val.link.is(node[1])).to.be.ok();
node = ctx.graph[soul];
expect(soul = Gun.val.link.is(node.where)).to.be.ok();
node = ctx.graph[soul];
expect(node.lat).to.be.ok();
expect(node.lng).to.be.ok();
expect(node.i).to.be(1);
done();
});
});
return; // TODO! Fix GUN to handle this!
data = {};
data.sneak = false;
data.both = {inside: 'meta data'};
data._ = {'#': 'shhh', data: {yay: 1}, spin: data.both};
test = Gun.ify(data);
expect(test.err.meta).to.be.ok(); // TODO: Fail: this passes, somehow? Fix ify code!
});
describe('Schedule', function(){
console.log("TODO: BUG! Upgrade SCHEDULE tests to new internal API!");
return;
it('one', function(done){
Gun.schedule(Gun.time.is(), function(){
expect(true).to.be(true);
done(); //setTimeout(function(){ done() },1);
});
});
it('many', function(done){
Gun.schedule(Gun.time.is() + 50, function(){
done.first = true;
});
Gun.schedule(Gun.time.is() + 100, function(){
done.second = true;
});
Gun.schedule(Gun.time.is() + 200, function(){
done.third = true;
expect(done.first).to.be(true);
expect(done.second).to.be(true);
expect(done.third).to.be(true);
done(); //setTimeout(function(){ done() },1);
});
});
});
describe('Union', function(){
console.log("TODO: BUG! Upgrade UNION tests to new internal API!");
return;
var gun = Gun();
it('fail', function(){
var prime = {
'asdf': {
_: {'#': 'asdf', '>':{
a: 'cheating'
}},
a: 0
}
}
expect(gun.__.graph['asdf']).to.not.be.ok();
var ctx = Gun.HAM.graph(gun, prime);
expect(ctx).to.not.be.ok();
});return;
it('basic', function(done){
var prime = {
'asdf': {
_: {'#': 'asdf', '>':{
a: Gun.time.is()
}},
a: 0
}
}
expect(gun.__.graph['asdf']).to.not.be.ok();
var ctx = Gun.union(gun, prime, function(){
expect(gun.__.graph['asdf'].a).to.be(0);
done();
});
});
it('disjoint', function(done){
var prime = {
'asdf': {
_: {'#': 'asdf', '>':{
b: Gun.time.is()
}},
b: 'c'
}
}
expect(gun.__.graph['asdf'].a).to.be(0);
expect(gun.__.graph['asdf'].b).to.not.be.ok();
var ctx = Gun.union(gun, prime, function(){
expect(gun.__.graph['asdf'].a).to.be(0);
expect(gun.__.graph['asdf'].b).to.be('c');
done();
});
});
it('mutate', function(done){
var prime = {
'asdf': {
_: {'#': 'asdf', '>':{
b: Gun.time.is()
}},
b: 'd'
}
}
expect(gun.__.graph['asdf'].b).to.be('c');
var ctx = Gun.union(gun, prime, function(){
expect(gun.__.graph['asdf'].b).to.be('d');
done();
});
});
it('disjoint past', function(done){
var prime = {
'asdf': {
_: {'#': 'asdf', '>':{
x: 0 // beginning of time!
}},
x: 'hi'
}
}
expect(gun.__.graph['asdf'].x).to.not.be.ok();
var ctx = Gun.union(gun, prime, function(){
expect(gun.__.graph['asdf'].x).to.be('hi');
done();
});
});
it('past', function(done){
var prime = {
'asdf': {
_: {'#': 'asdf', '>':{
x: Gun.time.is() - (60 * 1000) // above lower boundary, below now or upper boundary.
}},
x: 'hello'
}
}
expect(gun.__.graph['asdf'].x).to.be('hi');
var ctx = Gun.union(gun, prime, function(){
expect(gun.__.graph['asdf'].x).to.be('hello');
done();
});
});
it('future', function(done){
var prime = {
'asdf': {
_: {'#': 'asdf', '>':{
x: Gun.time.is() + (200) // above now or upper boundary, aka future.
}},
x: 'how are you?'
}
}
expect(gun.__.graph['asdf'].x).to.be('hello');
var now = Gun.time.is();
var ctx = Gun.union(gun, prime, function(){
expect(Gun.time.is() - now).to.be.above(100);
expect(gun.__.graph['asdf'].x).to.be('how are you?');
done();
});
});
var to = 5000;
it('disjoint future', function(done){
var prime = {
'asdf': {
_: {'#': 'asdf', '>':{
y: Gun.time.is() + (200) // above now or upper boundary, aka future.
}},
y: 'goodbye'
}
}
expect(gun.__.graph['asdf'].y).to.not.be.ok();
var now = Gun.time.is();
var ctx = Gun.union(gun, prime, function(){
expect(Gun.time.is() - now).to.be.above(100);
expect(gun.__.graph['asdf'].y).to.be('goodbye');
done();
});
});
it('disjoint future max', function(done){
var prime = {
'asdf': {
_: {'#': 'asdf', '>':{
y: Gun.time.is() + (2), // above now or upper boundary, aka future.
z: Gun.time.is() + (200) // above now or upper boundary, aka future.
}},
y: 'bye',
z: 'who'
}
}
expect(gun.__.graph['asdf'].y).to.be('goodbye');
expect(gun.__.graph['asdf'].z).to.not.be.ok();
var now = Gun.time.is();
var ctx = Gun.union(gun, prime, function(){
expect(Gun.time.is() - now).to.be.above(100);
expect(gun.__.graph['asdf'].y).to.be('bye');
expect(gun.__.graph['asdf'].z).to.be('who');
done(); //setTimeout(function(){ done() },1);
});
});
it('future max', function(done){
var prime = {
'asdf': {
_: {'#': 'asdf', '>':{
w: Gun.time.is() + (2), // above now or upper boundary, aka future.
x: Gun.time.is() - (60 * 1000), // above now or upper boundary, aka future.
y: Gun.time.is() + (200), // above now or upper boundary, aka future.
z: Gun.time.is() + (50) // above now or upper boundary, aka future.
}},
w: true,
x: 'nothing',
y: 'farewell',
z: 'doctor who'
}
}
expect(gun.__.graph['asdf'].w).to.not.be.ok();
expect(gun.__.graph['asdf'].x).to.be('how are you?');
expect(gun.__.graph['asdf'].y).to.be('bye');
expect(gun.__.graph['asdf'].z).to.be('who');
var now = Gun.time.is();
var ctx = Gun.union(gun, prime, function(){
expect(Gun.time.is() - now).to.be.above(100);
expect(gun.__.graph['asdf'].w).to.be(true);
expect(gun.__.graph['asdf'].x).to.be('how are you?');
expect(gun.__.graph['asdf'].y).to.be('farewell');
expect(gun.__.graph['asdf'].z).to.be('doctor who');
done(); //setTimeout(function(){ done() },1);
});
});
it('two nodes', function(done){ // chat app problem where disk dropped the last data, turns out it was a union problem!
var state = Gun.time.is();
var prime = {
'sadf': {
_: {'#': 'sadf', '>':{
1: state
}},
1: {'#': 'fdsa'}
},
'fdsa': {
_: {'#': 'fdsa', '>':{
msg: state
}},
msg: "Let's chat!"
}
}
expect(gun.__.graph['sadf']).to.not.be.ok();
expect(gun.__.graph['fdsa']).to.not.be.ok();
var ctx = Gun.union(gun, prime, function(){
expect(gun.__.graph['sadf'][1]).to.be.ok();
expect(gun.__.graph['fdsa'].msg).to.be("Let's chat!");
done();
});
});
it('append third node', function(done){ // chat app problem where disk dropped the last data, turns out it was a union problem!
var state = Gun.time.is();
var prime = {
'sadf': {
_: {'#': 'sadf', '>':{
2: state
}},
2: {'#': 'fads'}
},
'fads': {
_: {'#': 'fads', '>':{
msg: state
}},
msg: "hi"
}
}
expect(gun.__.graph['sadf']).to.be.ok();
expect(gun.__.graph['fdsa']).to.be.ok();
var ctx = Gun.union(gun, prime, function(){
expect(gun.__.graph['sadf'][1]).to.be.ok();
expect(gun.__.graph['sadf'][2]).to.be.ok();
expect(gun.__.graph['fads'].msg).to.be("hi");
done();
});
});
it('ify null', function(){
var node = Gun.union.ify(null, 'pseudo');
expect(Gun.node.soul(node)).to.be('pseudo');
});
it('ify node', function(){
var graph = {
'asdf': {
_: {'#': 'asdf', '>': {
x: Gun.time.is(),
y: Gun.time.is()
}},
x: 1,
y: 2
},
'soul': {
_: {'#': 'soul', '~': 1, '>': {
'asdf': Gun.time.is()
}},
'asdf': {'#': 'asdf'}
}
}
var node = Gun.union.ify(graph, 'soul');
expect(Gun.node.soul(node)).to.be('soul');
expect(node.x).to.be(1);
expect(node.y).to.be(2);
});
it('ify graph', function(){
var graph = {
'asdf': {
_: {'#': 'asdf', '>': {
a: Gun.time.is() - 2,
z: Gun.time.is() - 2
}},
a: 1,
z: 1
},
'fdsa': {
_: {'#': 'fdsa', '>': {
b: Gun.time.is() - 1,
z: Gun.time.is() - 1
}},
b: 2,
z: 2
},
'sadf': {
_: {'#': 'sadf', '>': {
c: Gun.time.is(),
z: Gun.time.is() - 100
}},
c: 3,
z: 3
},
'soul': {
_: {'#': 'soul', '~': 1, '>': {
'asdf': Gun.time.is(),
'fdsa': Gun.time.is(),
'sadf': Gun.time.is()
}},
'asdf': {'#': 'asdf'},
'fdsa': {'#': 'fdsa'},
'sadf': {'#': 'sadf'}
}
}
var node = Gun.union.ify(graph, 'soul');
expect(Gun.node.soul(node)).to.be('soul');
expect(node.a).to.be(1);
expect(node.b).to.be(2);
expect(node.c).to.be(3);
expect(node.z).to.be(2);
});
});
describe('API', function(){
var gopt = {wire:{put:function(n,cb){cb()},get:function(k,cb){cb()}}};
if(Gun.window && location.search){
/*console.log("LOCALHOST PEER MUST BE ON!");
var peer = {url: 'http://localhost:8765/gun'};
Gun.on('opt', function(root){
if(root.opt.test_no_peer){ return this.to.next(root) }
root.opt.peers = root.opt.peers || {};
root.opt.peers['http://localhost:8765/gun'] = peer;
this.to.next(root);
});*/
}
var goff = Gun();
Gun.statedisk = function(o,s,cb){
goff.get(s).put(o, cb, {turn: function(fn){fn()}});
};
var gun = Gun();
var nopasstun = function(done, g){
g = (g || gun)._.root;
setTimeout(function(){
expect(g.pass).to.not.be.ok();
expect(g.stun).to.not.be.ok();
done && done();
},9);
}
it.skip('gun chain separation', function(done){ // TODO: UNDO!
var gun = Gun();
var c1 = gun.put({hello: 'world'});
var c2 = gun.put({hi: 'earth'});
c1.on(function(val){
expect(val.hi).to.not.be.ok();
});
c2.on(function(val){
expect(val.hello).to.not.be.ok();
if(done.c){ return }
done(); done.c = 1;
});
});
describe.skip('timeywimey', function(){ // TODO: UNDO!
it('kitty', function(done){
var g1 = gun.put({hey: 'kitty'}).key('timeywimey/kitty');
var g2 = gun.get('timeywimey/kitty').on(function(val){
delete val._;
//console.log("kitty?", val);
expect(val.hey).to.be('kitty');
expect(val.hi).to.not.be.ok();
expect(val.hello).to.not.be.ok();
expect(val.foo).to.not.be.ok();
if(done.c){ return }
done(); done.c = 1;
});
});
it('kitty puppy', function(done){
var g3 = gun.put({hey: 'kitty'}).key('timeywimey/kitty/puppy');
var g4 = gun.put({hi: 'puppy'}).key('timeywimey/kitty/puppy');
var g5 = gun.get('timeywimey/kitty/puppy').on(function(val){
//delete val._;
//console.log("puppy?", val);
expect(val.hey).to.be('kitty');
expect(val.hi).to.be('puppy');
if(done.c){ return }
done(); done.c = 1;
});
});
it('hello', function(done){
gun.get('timeywimey/hello').on(function(val){
//delete val._;
//console.log("hello?", val);
expect(val.hello).to.be('world');
if(done.c){ return }
done(); done.c = 1;
});
gun.put({hello: 'world'}).key('timeywimey/hello');
});
it('hello foo', function(done){
gun.get('timeywimey/hello/foo').on(function(val){
//delete val._;
expect(val.hello).to.be('world');
if(val.foo){
expect(val.foo).to.be('bar');
if(done.c){ return }
done(); done.c = 1;
}
});
gun.put({hello: 'world'}).key('timeywimey/hello/foo');
gun.put({foo: 'bar'}).key('timeywimey/hello/foo');
});
it('all', function(done){
gun.put({hey: 'kitty'}).key('timeywimey/all');
gun.put({hi: 'puppy'}).key('timeywimey/all');
gun.get('timeywimey/all').on(function(val){
// console.log('all', done.c, val);
expect(val.hey).to.be('kitty');
expect(val.hi).to.be('puppy');
if(val.hello){
expect(val.hello).to.be('world');
done.hello = true;
}
if(val.foo){
expect(val.foo).to.be('bar');
if(done.c || !done.hello){ return }
done(); done.c = 1;
}
});
gun.put({hello: 'world'}).key('timeywimey/all');
gun.put({foo: 'bar'}).key('timeywimey/all');
});
});
describe('predictable souls', function(){
it('public', function(done){
gun.get('z').get('y').get('x').put({c: {b: {a: 1}}}, function(){
if(done.c){ return } done.c = 1;
var g = gun._.graph;
expect(g['z']).to.be.ok();
expect(g['z/y']).to.be.ok();
expect(g['z/y/x']).to.be.ok();
expect(g['z/y/x/c']).to.be.ok();
expect(g['z/y/x/c/b']).to.be.ok();
nopasstun(done, gun);
});
});
it('no not found on incremental write', function(done){
gun.get('nnfoiw').get('y').put({a:1}, function(ack){
if(ack.err){ return }
nopasstun(done, gun);
})
});
it('public mix', function(done){
var ref = gun.get('zasdf').put({a: 9});
var at = gun.get('zfdsa').get('y').get('x').get('c').put(ref);
at.get('foo').get('bar').put('yay', function(ack){ done.a = 1; end() });
ref.get('foo').get('ah').put(1, function(ack){ done.b = 1; end() });
function end(ack){
if(!done.a || !done.b){ return }
if(done.c){ return } done.c = 1;
var g = gun._.graph;
expect(Object.keys(g['zasdf']||'').sort()).to.be.eql(['_', 'a', 'foo'].sort());
expect(Object.keys(g['zasdf/foo']||'').sort()).to.be.eql(['_', 'bar', 'ah'].sort());
nopasstun(done, gun);
};
//setTimeout(function(){ console.log('???', gun._.stun); }, 1700);
});
});
describe('plural chains', function(){
this.timeout(9000);
it('uncached synchronous map on', function(done){
/*
Biggest challenges so far:
- Unsubscribe individual mapped next. !
- Performance deduplication on asking relation's next. !
- Replying immediately to parent cached contexts.
- Performant read lock on write contexts.
- Proxying event across maps.
*/
Gun.statedisk({ alice: { age: 26, name: "Alice", pet: {a:1, name: "Fluffy"} }, bob: { age: 29, name: "Bob!", pet: {b:2, name: "Frisky"} } }, 'u/m', function(){
var check = {}, count = {};
gun.get('u/m').map().on(function(v,f){
check[f] = v;
count[f] = (count[f] || 0) + 1;
//console.log("***********", f, v);
if(check.alice && check.bob){
clearTimeout(done.to);
done.to = setTimeout(function(){
expect(check.alice.age).to.be(26);
expect(check.alice.name).to.be('Alice');
expect('string' == typeof Gun.valid(check.alice.pet)).to.be.ok();
//expect(count.alice).to.be(1);
expect(check.bob.age).to.be(29);
expect(check.bob.name).to.be('Bob!');
expect('string' == typeof Gun.valid(check.bob.pet)).to.be.ok();
//expect(count.bob).to.be(1);
nopasstun(done, gun);
},10);
}
});
}, 1000);
});
it('uncached synchronous map get on', function(done){
Gun.statedisk({
alice: {
age: 26,
name: "alice",
pet: {a:1, name: "Fluffy"}
},
bob: {
age: 29,
name: "bob",
pet: {b:2, name: "Frisky"}
}
}, 'u/m/p', function(){
var check = {}, count = {};
gun.get('u/m/p').map().get('name').on(function(v,f){
//console.log("*****************", f, v);
check[v] = f;
count[v] = (count[v] || 0) + 1;
if(check.alice && check.bob){
clearTimeout(done.to);
done.to = setTimeout(function(){
expect(check.alice).to.be('name');
expect(check.bob).to.be('name');
//expect(count.alice).to.be(1);
//expect(count.bob).to.be(1);
nopasstun(done, gun);
},10);
}
});
}, 1000);
});
it('uncached synchronous map get on node', function(done){
Gun.statedisk({
alice: {
age: 26,
name: "alice",
pet: {a:1, name: "Fluffy"}
},
bob: {
age: 29,
name: "bob",
pet: {b:2, name: "Frisky"}
}
}, 'u/m/p/n', function() {
var check = {}, count = {};
gun.get('u/m/p/n').map().get('pet').on(function(v,f){
//console.log("********************", f,v);
check[v.name] = v;
count[v.name] = (count[v.name] || 0) + 1;
if(check.Fluffy && check.Frisky){
clearTimeout(done.to);
done.to = setTimeout(function(){
expect(check.Fluffy.a).to.be(1);
expect(check.Frisky.b).to.be(2);
//expect(count.Fluffy).to.be(1);
//expect(count.Frisky).to.be(1);
//expect(count['undefined']).to.not.be.ok();
if(done.c){return}done.c=1;
nopasstun(done, gun);
},10);
}
});
}, 1000);
});
it('uncached synchronous map get on node get', function(done){
var gun = Gun();
Gun.statedisk({
alice: {
age: 26,
name: "alice",
pet: {a:1, name: "Fluffy"}
},
bob: {
age: 29,
name: "bob",
pet: {b:2, name: "Frisky"}
}
}, 'u/m/p/n/p', function() {
var check = {}, count = {};
//console.debug.i=1;console.log('-------------------');
gun.get('u/m/p/n/p').map().get('pet').get('name').on(function(v,f){
check[v] = f;
count[v] = (count[v] || 0) + 1;
//console.log("*****************", f, v);
if(check.Fluffy && check.Frisky){
clearTimeout(done.to);
done.to = setTimeout(function(){
expect(check.Fluffy).to.be('name');
expect(check.Frisky).to.be('name');
//console.log("????", gun._.graph);
//Gun.obj.map(gun._.graph, function(n,s){
Object.keys(gun._.graph).forEach(function(s,n){ n = gun._.graph[s];
if('u/m/p/n/p' === s){ return }
var a = Object.keys(n);//Gun.obj.map(n, function(v,f,t){t(v)});
expect(a.length).to.be(2); // make sure that ONLY the selected properties were loaded, not the whole node.
});
//expect(count.Fluffy).to.be(1);
//expect(count.Frisky).to.be(1);
nopasstun(done, gun);
},10);
}
});
}, 1000);
});
it('uncached synchronous map on mutate', function(done){
Gun.statedisk({
alice: {
age: 26,
name: "Alice",
pet: {a:1, name: "Fluffy"}
},
bob: {
age: 29,
name: "Bob",
pet: {b:2, name: "Frisky"}
}
}, 'u/m/mutate', function() {
var check = {}, count = {};
gun.get('u/m/mutate').map().get('name').get(function(at,ev){
var e = at.err, v = at.put, f = at.get;
//console.log("****************", f,v);
check[v] = f;
count[v] = (count[v] || 0) + 1;
if(check.Alice && check.Bob && check['undefined']){
clearTimeout(done.to);
done.to = setTimeout(function(){
//expect(count.Alice).to.be(1);
//expect(count.Bob).to.be(1);
//expect(count['undefined']).to.be(1);
if(done.c){ return } done.c = 1;
nopasstun(done, gun);
},10);
}
});
setTimeout(function(){
gun.get('u/m/mutate').get('alice').put(7);
}, 300);
}, 1000);
});
it('uncached synchronous map on mutate node', function(done){
Gun.statedisk({
alice: {_:{'#':'umaliceo'},
age: 26,
name: "Alice",
pet: {a:1, name: "Fluffy"}
},
bob: {
age: 29,
name: "Bob",
pet: {b:2, name: "Frisky"}
}
}, 'u/m/mutate/n', function() {
var check = {}, count = {};
gun.get('u/m/mutate/n').map().get('name').get(function(at,ev){
var e = at.err, v = at.put, f = at.get;
check[v] = f;
count[v] = (count[v] || 0) + 1;
//console.log("************", f,v);
if(check.Alice && check.Bob && check['undefined'] && check['Alice Zzxyz']){
clearTimeout(done.to);
done.to = setTimeout(function(){
expect(done.last).to.be.ok();
expect(check['Alice Aabca']).to.not.be.ok();
expect(count.Alice).to.be(1);
expect(count.Bob).to.be(1);
expect(count['undefined']).to.be(1);
expect(count['Alice Zzxyz']).to.be(1);
nopasstun(done, gun);
},200);
}
});
setTimeout(function(){
gun.get('u/m/mutate/n').get('alice').put({
_:{'#':'u/m/m/n/soul'},
name: 'Alice Zzxyz'
});
setTimeout(function(){
gun.get('umaliceo').put({
name: 'Alice Aabca'
});
done.last = true;
}, 10);
}, 300);
}, 1000);
});
it('uncached synchronous map on mutate node uncached', function(done){
Gun.statedisk({
alice: {_:{'#':'umaliceo1'},
age: 26,
name: "Alice",
pet: {a:1, name: "Fluffy"}
},
bob: {
age: 29,
name: "Bob",
pet: {b:2, name: "Frisky"}
}
}, 'u/m/mutate/n/u', function() {
var check = {}, count = {};
gun.get('u/m/mutate/n/u').map().on(function(v,f){
check[v.name] = f;
count[v.name] = (count[v.name] || 0) + 1;
if(check.Alice && check.Bob && check['Alice Zzxyz']){
clearTimeout(done.to);
//console.log("****", f, v)
done.to = setTimeout(function(){
expect(done.last).to.be.ok();
//expect(check['Alice Aabca']).to.not.be.ok();
//expect(count['Alice']).to.be(1);
//expect(count['Bob']).to.be(1);
//expect(count['Alice Zzxyz']).to.be(1);
if(done.c){ return } done.c = 1;
nopasstun(done, gun);
},200);
}
});
setTimeout(function(){
Gun.statedisk({ name: 'Alice Zzxyz' }, 'u/m/m/n/u/soul', function() {
//console.debug.i=1;console.log("---------------");
gun.get('u/m/mutate/n/u').put({
alice: {'#':'u/m/m/n/u/soul'},
});
/*
{
users: {_:#users
alice: {#newalice}
}
}
*/
setTimeout(function(){
gun.get('umaliceo1').put({
name: 'Alice Aabca'
});
done.last = true;
}, 10);
}, 1000);
}, 300);
}, 1000);
});
it('uncached synchronous map on get mutate node uncached', function(done){
Gun.statedisk({
alice: {_:{'#':'umaliceo2'},
age: 26,
name: "Alice",
pet: {a:1, name: "Fluffy"}
},
bob: {
age: 29,
name: "Bob",
pet: {b:2, name: "Frisky"}
}
}, 'u/m/p/mutate/n/u', function() {
var check = {}, count = {};
gun.get('u/m/p/mutate/n/u').map().get('name').on(function(v,f){
check[v] = f;
count[v] = (count[v] || 0) + 1;
//console.log("*************", f,v);
if(check.Alice && check.Bob && check['Alice Zzxyz']){
clearTimeout(done.to);
done.to = setTimeout(function(){
var a = Object.keys(gun._.graph['u/m/p/m/n/u/soul']); //Gun.obj.map(gun._.graph['u/m/p/m/n/u/soul'], function(v,f,t){t(v)});
expect(a.length).to.be(2);
expect(done.last).to.be.ok();
expect(check['Alice Aabca']).to.not.be.ok();
//expect(count.Alice).to.be(1);
//expect(count.Bob).to.be(1);
//expect(count['Alice Zzxyz']).to.be(1);
nopasstun(done, gun);
},200);
}
});
setTimeout(function(){
Gun.statedisk({ name: 'Alice Zzxyz', age: 34 }, 'u/m/p/m/n/u/soul', function() {
gun.get('u/m/p/mutate/n/u').put({
alice: {'#':'u/m/p/m/n/u/soul'},
});
setTimeout(function(){
gun.get('umaliceo2').put({
name: 'Alice Aabca'
});
done.last = true;
}, 10);
}, 1000);
}, 300);
}, 1000);
});
it('uncached synchronous map on get node mutate node uncached', function(done){
Gun.statedisk({
alice: {_:{'#':'umaliceo3'},
age: 26,
name: "Alice",
pet: {_:{'#':'sflufso'},a:1, name: "Fluffy"}
},
bob: {
age: 29,
name: "Bob",
pet: {b:2, name: "Frisky"}
}
}, 'u/m/p/n/mutate/n/u', function() {
var check = {}, count = {};
gun.get('u/m/p/n/mutate/n/u').map().get('pet').on(function(v,f){
check[v.name] = f;
count[v.name] = (count[v.name] || 0) + 1;
//console.log("*****************", f,v, check);
if(check.Fluffy && check.Frisky && check.Fuzzball){
clearTimeout(done.to);
done.to = setTimeout(function(){
expect(done.last).to.be.ok();
expect(check['Fluffs']).to.not.be.ok();
expect(count.Fluffy).to.be(1);
expect(count.Frisky).to.be(1);
expect(count.Fuzzball).to.be(1);
nopasstun(done, gun);
},200);
}
});
setTimeout(function(){
Gun.statedisk({
name: 'Alice Zzxyz', age: 34,
pet: {c:3, name: "Fuzzball"}
}, 'alice/fuzz/soul', function() {
gun.get('u/m/p/n/mutate/n/u').put({
alice: {'#':'alice/fuzz/soul'},
});
setTimeout(function(){
gun.get('sflufso').put({
name: 'Fluffs'
});
done.last = true;
}, 10);
}, 1000);
}, 300);
}, 1000);
});
it("unlink deeply nested", function(done){
Gun.statedisk({
a: {_:{'#':'audn'},
age: 26,
name: "Alice",
b: {_:{'#':'budn'}, c: {_:{'#':'cudn'}, id: 'first', level: 3}, level: 2}
}
}, 'udn', function() {
var check = {}, count = {};
gun.get('udn').get('a').get('b').get('c').on(function(data){
//console.log("udn.a.b.c:", data);
check[data.id] = 1;
count[data.id] = (count[data.id] || 0) + 1;
expect(data.foo).to.not.be.ok();
//console.log("*****************", f,v, check);
if(check.first && check.other){
clearTimeout(done.to);
done.to = setTimeout(function(){
expect(done.last).to.be.ok();
expect(check.firsta).to.not.be.ok();
expect(count.first).to.be(1);
expect(count.other).to.be(1);
nopasstun(done, gun);
},200);
}
});
setTimeout(function(){
Gun.statedisk({
name: 'Alice2', age: 34,
b: {_:{'#':'2budn'}, c: {_:{'#':'2cudn'}, id: 'other', level: 3}, level: 2}
}, '2audn', function() {
//console.only.i=1;console.log('=============================');
gun.get('udn').put({
a: {'#':'2audn'}
});
setTimeout(function(){
//console.log("- - - - - - - - - - - -");
gun.get('cudn').put({id: 'firsta', foo: 'bar'});
done.last = 1;
}, 50);
});
},50);
});
});
it("get before put in memory", function(done){
var gun = Gun();
var check = {};
var count = {};
gun.get('g/n/m/f/l/n/r').map().on(function(v,f){
//console.log("***********", f,v);
check[f] = v;
count[f] = (count[f] || 0) + 1;
if(check.alice && check.bob && check.alice.PhD){
clearTimeout(done.to);
done.to = setTimeout(function(){
expect(check.alice.age).to.be(24);
expect(check.bob.age).to.be(26);
expect(check.alice.PhD).to.be(true);
//expect(count.alice).to.be(2);
//expect(count.bob).to.be(1);
if(done.c){return} done.c=1;
nopasstun(done, gun);
},50);
}
});
gun.put({_:{'#':'g/n/m/f/l/n/r'},
alice: {_:{'#':'GALICE1'},
name: "alice",
age: 24,
spouse: {
name: "carl",
age: 25,
work: {
name: "GUN INC"
}
},
bout: {huh:1}
},
bob: {
name: "bob",
age: 26,
spouse: {
name: "diana",
age: 27,
work: {
name: "ACME INC"
}
}
}
});
setTimeout(function(){
gun.get('GALICE1').put({PhD: true});
},300);
});
it("in memory get after", function(done){
var gun = Gun();
gun.put({_:{'#':'g/n/m/f/l/n'},
alice: {_:{'#':'GALICE2'},
name: "alice",
age: 24,
spouse: {
name: "carl",
age: 25,
work: {
name: "GUN INC"
}
},
bout: {huh:1}
},
bob: {
name: "bob",
age: 26,
spouse: {
name: "diana",
age: 27,
work: {
name: "ACME INC"
}
}
}
});
var check = {};
//gun.get('g/n/m/f/l/n').get('bob.spouse.work').on(function(v,f){ console.log("!!!!!!!!!", f, v);});return;
gun.get('g/n/m/f/l/n').map().on(function(v,f){
check[f] = v;
//console.log("*******************", f, v);
if(check.alice && check.bob && check.alice.PhD){
clearTimeout(done.to);
done.to = setTimeout(function(){
expect(check.alice.age).to.be(24);
expect(check.bob.age).to.be(26);
expect(check.alice.PhD).to.be(true);
nopasstun(done, gun);
},10);
}
});
setTimeout(function(){
gun.get('GALICE2').put({PhD: true});
},300);
});
it("in memory get before map get", function(done){
var gun = Gun();
var check = {};
gun.get('g/n/m/f/l/n/b/p').map().get('name').on(function(v,f){
check[v] = f;
//console.log("****************", f,v, gun);
if(check.alice && check.bob && check.Alice){
clearTimeout(done.to);
done.to = setTimeout(function(){
expect(check.alice).to.be('name');
expect(check.bob).to.be('name');
expect(check.Alice).to.be('name');
if(done.c){return}done.c=1;
nopasstun(done, gun);
},10);
}
});
gun.put({_:{'#':'g/n/m/f/l/n/b/p'},
alice: {_:{'#':'GALICE3'},
name: "alice",
age: 24,
spouse: {
name: "carl",
age: 25,
work: {
name: "GUN INC"
}
},
bout: {huh:1}
},
bob: {
name: "bob",
age: 26,
spouse: {
name: "diana",
age: 27,
work: {
name: "ACME INC"
}
}
}
});
setTimeout(function(){
//console.debug.i=1;console.log("-------------");
gun.get('GALICE3').put({name: 'Alice'});
},300);
});
it("in memory get after map get", function(done){
var gun = Gun();
gun.put({_:{'#':'g/n/m/f/l/n/m/p'},
alice: {_:{'#':'GALICE4'},
name: "alice",
age: 24,
spouse: {
name: "carl",
age: 25,
work: {
name: "GUN INC"
}
},
bout: {huh:1}
},
bob: {
name: "bob",
age: 26,
spouse: {
name: "diana",
age: 27,
work: {
name: "ACME INC"
}
}
}
});
var check = {};
gun.get('g/n/m/f/l/n/m/p').map().get('name').on(function(v,f){
check[v] = f;
//console.log("*****************", f,v);
if(check.alice && check.bob && check.Alice){
clearTimeout(done.to);
done.to = setTimeout(function(){
expect(check.alice).to.be('name');
expect(check.bob).to.be('name');
expect(check.Alice).to.be('name');
nopasstun(done, gun);
},10);
}
});
setTimeout(function(){
gun.get('GALICE4').put({name: 'Alice'});
},300);
});
it("in memory get before map get get", function(done){
var gun = Gun();
var check = {};
gun.get('g/n/m/f/l/n/b/p/p/p').map().get('spouse').get('work').on(function(v,f){
check[v.name] = f;
//console.log("*******", f, v);
if(check['GUN INC'] && check['ACME INC'] && check['ACME INC.']){
clearTimeout(done.to);
done.to = setTimeout(function(){
expect(check['GUN INC']).to.be('work');
expect(check['ACME INC']).to.be('work');
expect(check['ACME INC.']).to.be('work');
if(done.c){return}done.c=1;
nopasstun(done, gun);
},10);
}
});
gun.put({_:{'#':'g/n/m/f/l/n/b/p/p/p'},
alice: {
name: "alice",
age: 24,
spouse: {
name: "carl",
age: 25,
work: {
name: "GUN INC"
}
},
bout: {huh:1}
},
bob: {
name: "bob",
age: 26,
spouse: {
name: "diana",
age: 27,
work: {_:{'#':'CCINEMA1'},
name: "ACME INC"
}
}
}
});
setTimeout(function(){
//console.debug.i=1;console.log("----------------");
gun.get('CCINEMA1').put({name: 'ACME INC.'});
},300);
});
it("in memory get after map get get", function(done){
var gun = Gun();
gun.put({_:{'#':'g/n/m/f/l/n/b/p/p/p/a'},
alice: {
name: "alice",
age: 24,
spouse: {
name: "carl",
age: 25,
work: {
name: "GUN INC"
}
},
bout: {huh:1}
},
bob: {
name: "bob",
age: 26,
spouse: {
name: "diana",
age: 27,
work: {_:{'#':'CCINEMA2'},
name: "ACME INC"
}
}
}
});
var check = {};
gun.get('g/n/m/f/l/n/b/p/p/p/a').map().get('spouse').get('work').on(function(v,f){
check[v.name] = f;
if(check['GUN INC'] && check['ACME INC'] && check['ACME INC.']){
clearTimeout(done.to);
done.to = setTimeout(function(){
expect(check['GUN INC']).to.be('work');
expect(check['ACME INC']).to.be('work');
expect(check['ACME INC.']).to.be('work');
nopasstun(done, gun);
},10);
}
});
setTimeout(function(){
gun.get('CCINEMA2').put({name: 'ACME INC.'});
},300);
});
it("in memory get before map map", function(done){
var gun = Gun();
var check = {};
gun.get('g/n/m/f/l/n/b/a/m/m').map().map().on(function(v,f){
check[f] = v;
//console.log("****************", f,v);
if(check.alice && check.bob && check.GUN && check.ACME && check.ACME.corp){
clearTimeout(done.to);
done.to = setTimeout(function(){
expect(check.alice.name).to.be('alice');
expect(check.alice.age).to.be(24);
expect('string' == typeof Gun.valid(check.alice.spouse)).to.be.ok();
expect(check.bob.name).to.be('bob');
expect(check.bob.age).to.be(26);
expect('string' == typeof Gun.valid(check.bob.spouse)).to.be.ok();
expect(check.GUN.name).to.be('GUN');
expect(check.ACME.name).to.be('ACME');
expect(check.ACME.corp).to.be('C');
if(done.c){return}done.c=1;
nopasstun(done, gun);
},10);
}
});
//console.debug.i=1;console.log("------------------------");
gun.put({_:{'#':'g/n/m/f/l/n/b/a/m/m'},
users: {
alice: {
name: "alice",
age: 24,
spouse: {
name: "carl",
age: 25
},
bout: {huh:1}
},
bob: {
name: "bob",
age: 26,
spouse: {
name: "diana",
age: 27
}
}
},
companies: {
GUN: {
name: "GUN"
},
ACME: {_:{'#':"CCINEMA3"},
name: "ACME"
}
}
});
setTimeout(function(){
//console.debug.i=1;console.log("-------------");
gun.get('CCINEMA3').put({corp: "C"});
},300);
});
it("in memory get after map map", function(done){
var gun = Gun();
gun.put({_:{'#':'g/n/m/f/l/n/b/m/m'},
users: {
alice: {
name: "alice",
age: 24,
spouse: {
name: "carl",
age: 25
},
bout: {huh:1}
},
bob: {
name: "bob",
age: 26,
spouse: {
name: "diana",
age: 27
}
}
},
companies: {
GUN: {
name: "GUN"
},
ACME: {_:{'#':"CCINEMA4"},
name: "ACME"
}
}
});
var check = {};
gun.get('g/n/m/f/l/n/b/m/m').map().map().on(function(v,f){
check[f] = v;
//console.log("***************", f,v);
if(check.alice && check.bob && check.GUN && check.ACME && check.ACME.corp){
clearTimeout(done.to);
done.to = setTimeout(function(){
expect(check.alice.name).to.be('alice');
expect(check.alice.age).to.be(24);
expect('string' == typeof Gun.valid(check.alice.spouse)).to.be.ok();
expect(check.bob.name).to.be('bob');
expect(check.bob.age).to.be(26);
expect('string' == typeof Gun.valid(check.bob.spouse)).to.be.ok();
expect(check.GUN.name).to.be('GUN');
expect(check.ACME.name).to.be('ACME');
expect(check.ACME.corp).to.be('C');
nopasstun(done, gun);
},10);
}
});
setTimeout(function(){
gun.get('CCINEMA4').put({corp: "C"});
},300);
});
it("in memory get before map map get", function(done){
var gun = Gun();
var check = {};
gun.get('g/n/m/f/l/n/b/m/m/p').map().map().get('name').on(function(v,f){
check[v] = f;
//console.log("***********", f,v);
if(check.alice && check.bob && check.GUN && check.ACME && check.ACMEINC){
clearTimeout(done.to);
done.to = setTimeout(function(){
expect(check.alice).to.be('name');
expect(check.bob).to.be('name');
expect(check.GUN).to.be('name');
expect(check.ACME).to.be('name');
expect(check.ACMEINC).to.be('name');
if(done.c){return}done.c=1;
nopasstun(done, gun);
},10);
}
});
gun.put({_:{'#':'g/n/m/f/l/n/b/m/m/p'},
users: {
alice: {
name: "alice",
age: 24,
spouse: {
name: "carl",
age: 25
},
bout: {huh:1}
},
bob: {
name: "bob",
age: 26,
spouse: {
name: "diana",
age: 27
}
}
},
companies: {
GUN: {
name: "GUN"
},
ACME: {_:{'#':"CCINEMA5"},
name: "ACME"
}
}
});
setTimeout(function(){
gun.get('CCINEMA5').put({name: "ACMEINC"});
},300);
});
it("in memory get after map map get", function(done){
var gun = Gun();
var check = {};
gun.put({_:{'#':'g/n/m/f/l/n/b/a/m/m/p'},
users: {
alice: {
name: "alice",
age: 24,
spouse: {
name: "carl",
age: 25
},
bout: {huh:1}
},
bob: {
name: "bob",
age: 26,
spouse: {
name: "diana",
age: 27
}
}
},
companies: {
GUN: {
name: "GUN"
},
ACME: {_:{'#':'CCINEMA6'},
name: "ACME"
}
}
});
gun.get('g/n/m/f/l/n/b/a/m/m/p').map().map().get('name').on(function(v,f){
check[v] = f;
//console.log("************", f,v);
if(check.alice && check.bob && check.GUN && check.ACME && check.ACMEINC){
clearTimeout(done.to);
done.to = setTimeout(function(){
expect(check.alice).to.be('name');
expect(check.bob).to.be('name');
expect(check.GUN).to.be('name');
expect(check.ACME).to.be('name');
expect(check.ACMEINC).to.be('name');
nopasstun(done, gun);
},10);
}
});
setTimeout(function(){
gun.get('CCINEMA6').put({name: "ACMEINC"});
},300);
});
it("in memory get before map map get get", function(done){
var gun = Gun();
var check = {};
gun.get('g/n/m/f/l/n/b/m/m/p/p').map().map().get('address').get('state').on(function(v,f){
check[v] = f;
if(check.QR && check.NY && check.CA && check.TX && check.MA){
clearTimeout(done.to);
done.to = setTimeout(function(){
expect(check.QR).to.be('state');
expect(check.NY).to.be('state');
expect(check.CA).to.be('state');
expect(check.TX).to.be('state');
expect(check.MA).to.be('state');
if(done.c){return}done.c=1;
nopasstun(done, gun);
},10);
}
});
gun.put({_:{'#':'g/n/m/f/l/n/b/m/m/p/p'},
users: {
alice: {
name: "alice",
age: 24,
address: {_:{'#':'QUANGO'},
state: "MA"
},
spouse: {
name: "carl",
age: 25
},
bout: {huh:1}
},
bob: {
name: "bob",
age: 26,
address: {
state: "TX"
},
spouse: {
name: "diana",
age: 27
}
}
},
companies: {
GUN: {
name: "GUN",
address: {
state: "CA"
}
},
ACME: {
name: "ACME",
address: {
state: "NY"
}
}
}
});
setTimeout(function(){
gun.get('QUANGO').put({state: 'QR'});
},300);
});
it("in memory get after map map get get", function(done){
var gun = Gun();
gun.put({_:{'#':'g/n/m/f/l/n/b/a/m/m/p/p'},
users: {
alice: {
name: "alice",
age: 24,
address: {_:{'#':'QUANGO1'},
state: "MA"
},
spouse: {
name: "carl",
age: 25
},
bout: {huh:1}
},
bob: {
name: "bob",
age: 26,
address: {
state: "TX"
},
spouse: {
name: "diana",
age: 27
}
}
},
companies: {
GUN: {
name: "GUN",
address: {
state: "CA"
}
},
ACME: {
name: "ACME",
address: {
state: "NY"
}
}
}
});
var check = {};
gun.get('g/n/m/f/l/n/b/a/m/m/p/p').map().map().get('address').get('state').on(function(v,f){
check[v] = f;
if(check.QR && check.NY && check.CA && check.TX && check.MA){
clearTimeout(done.to);
done.to = setTimeout(function(){
expect(check.QR).to.be('state');
expect(check.NY).to.be('state');
expect(check.CA).to.be('state');
expect(check.TX).to.be('state');
expect(check.MA).to.be('state');
nopasstun(done, gun);
},10);
}
});
setTimeout(function(){
gun.get('QUANGO1').put({state: 'QR'});
},300);
});
it("in memory get before map map get get get", function(done){
var gun = Gun();
var check = {};
gun.get('g/n/m/f/l/n/b/m/m/p/p/p').map().map().get('address').get('state')
.get('code')
.on(function(v,f){
check[v] = f;
if(check.QR && check.NY && check.CA && check.TX && check.MA){
clearTimeout(done.to);
done.to = setTimeout(function(){
expect(check.QR).to.be('code');
expect(check.NY).to.be('code');
expect(check.CA).to.be('code');
expect(check.TX).to.be('code');
expect(check.MA).to.be('code');
if(done.c){return}done.c=1;
nopasstun(done, gun);
},10);
}
});
gun.put({_:{'#':'g/n/m/f/l/n/b/m/m/p/p/p'},
users: {
alice: {
name: "alice",
age: 24,
address: {
state: {_:{'#':'HIPPOM'},
code: "MA",
county: {
MA1: "First"
}
}
},
spouse: {
name: "carl",
age: 25
},
bout: {huh:1}
},
bob: {
name: "bob",
age: 26,
address: {
state: {
code: "TX",
county: {
TX1: "First"
}
}
},
spouse: {
name: "diana",
age: 27
}
}
},
companies: {
GUN: {
name: "GUN",
address: {
state: {
code: "CA",
county: {
CA1: "First"
}
}
}
},
ACME: {
name: "ACME",
address: {
state: {
code: "NY",
county: {
NY1: "First"
}
}
}
}
}
});
setTimeout(function(){
gun.get('HIPPOM').put({code: 'QR'});
},300);
});
it("in memory get before after map map get get get", function(done){
var gun = Gun();
var check = {};
gun.put({_:{'#':'g/n/m/f/l/n/b/a/m/m/p/p/p'},
users: {
alice: {
name: "alice",
age: 24,
address: {
state: {_:{'#':'HIPPOM1'},
code: "MA",
county: {
MA1: "First"
}
}
},
spouse: {
name: "carl",
age: 25
},
bout: {huh:1}
},
bob: {
name: "bob",
age: 26,
address: {
state: {
code: "TX",
county: {
TX1: "First"
}
}
},
spouse: {
name: "diana",
age: 27
}
}
},
companies: {
GUN: {
name: "GUN",
address: {
state: {
code: "CA",
county: {
CA1: "First"
}
}
}
},
ACME: {
name: "ACME",
address: {
state: {
code: "NY",
county: {
NY1: "First"
}
}
}
}
}
});
gun.get('g/n/m/f/l/n/b/a/m/m/p/p/p').map().map().get('address').get('state')
.get('code')
.on(function(v,f){
check[v] = f;
//console.log("***********", f,v);
if(check.QR && check.NY && check.CA && check.TX && check.MA){
clearTimeout(done.to);
done.to = setTimeout(function(){
expect(check.QR).to.be('code');
expect(check.NY).to.be('code');
expect(check.CA).to.be('code');
expect(check.TX).to.be('code');
expect(check.MA).to.be('code');
nopasstun(done, gun);
},10);
}
});
setTimeout(function(){
gun.get('HIPPOM1').put({code: 'QR'});
},300);
});
it("in memory get before map map get get node", function(done){
var gun = Gun();
var check = {};
gun.get('g/n/m/f/l/n/b/m/m/p/p/n').map().map().get('address').get('state').on(function(v,f){
check[v.code] = f;
//console.log("************", f, v);
if(check.QR && check.NY && check.CA && check.TX && check.MA){
clearTimeout(done.to);
done.to = setTimeout(function(){
expect(check.QR).to.be('state');
expect(check.NY).to.be('state');
expect(check.CA).to.be('state');
expect(check.TX).to.be('state');
expect(check.MA).to.be('state');
if(done.c){return}done.c=1;
nopasstun(done, gun);
},10);
}
});
gun.put({_:{'#':'g/n/m/f/l/n/b/m/m/p/p/n'},
users: {
alice: {
name: "alice",
age: 24,
address: {
state: {_:{'#':'HIPPOM3'},
code: "MA",
county: {
MA1: "First"
}
}
},
spouse: {
name: "carl",
age: 25
},
bout: {huh:1}
},
bob: {
name: "bob",
age: 26,
address: {
state: {
code: "TX",
county: {
TX1: "First"
}
}
},
spouse: {
name: "diana",
age: 27
}
}
},
companies: {
GUN: {
name: "GUN",
address: {
state: {
code: "CA",
county: {
CA1: "First"
}
}
}
},
ACME: {
name: "ACME",
address: {
state: {
code: "NY",
county: {
NY1: "First"
}
}
}
}
}
});
setTimeout(function(){
gun.get('HIPPOM3').put({code: 'QR'});
},300);
});
it("in memory get before after map map get get node", function(done){
var gun = Gun();
var check = {};
gun.put({_:{'#':'g/n/m/f/l/n/b/a/m/m/p/p/n'},
users: {
alice: {
name: "alice",
age: 24,
address: {
state: {_:{'#':'HIPPOM4'},
code: "MA",
county: {
MA1: "First"
}
}
},
spouse: {
name: "carl",
age: 25
},
bout: {huh:1}
},
bob: {
name: "bob",
age: 26,
address: {
state: {
code: "TX",
county: {
TX1: "First"
}
}
},
spouse: {
name: "diana",
age: 27
}
}
},
companies: {
GUN: {
name: "GUN",
address: {
state: {
code: "CA",
county: {
CA1: "First"
}
}
}
},
ACME: {
name: "ACME",
address: {
state: {
code: "NY",
county: {
NY1: "First"
}
}
}
}
}
});
gun.get('g/n/m/f/l/n/b/a/m/m/p/p/n').map().map().get('address').get('state').on(function(v,f){
check[v.code] = f;
//console.log("**********", f, v);
if(check.QR && check.NY && check.CA && check.TX && check.MA){
clearTimeout(done.to);
done.to = setTimeout(function(){
expect(check.QR).to.be('state');
expect(check.NY).to.be('state');
expect(check.CA).to.be('state');
expect(check.TX).to.be('state');
expect(check.MA).to.be('state');
nopasstun(done, gun);
},10);
}
});
setTimeout(function(){
gun.get('HIPPOM4').put({code: 'QR'});
},300);
});
it("in memory get after map map get get get map", function(done){
var gun = Gun();
var check = {};
gun.put({_:{'#':'g/n/m/f/l/n/b/a/m/m/p/p/p/n'},
users: {
alice: {
name: "alice",
age: 24,
address: {
state: {
code: "MA",
county: {
MA1: "First"
,MA2: "Second"
}
}
},
spouse: {
name: "carl",
age: 25
},
bout: {huh:1}
},
bob: {
name: "bob",
age: 26,
address: {
state: {
code: "TX",
county: {
TX1: "First"
,TX2: "Second"
}
}
},
spouse: {
name: "diana",
age: 27
}
}
},
companies: {
GUN: {
name: "GUN",
address: {
state: {
code: "CA",
county: {
CA1: "First"
,CA2: "Second"
}
}
}
},
ACME: {
name: "ACME",
address: {
state: {
code: "NY",
county: {_:{'#':'NYCOUNT'},
NY1: "First"
,NY2: "Second"
}
}
}
}
}
});
gun.get('g/n/m/f/l/n/b/a/m/m/p/p/p/n').map().map().get('address').get('state').get('county').map().on(function(v,f){
check[f] = v;
//console.log("****************", f,v);
if(check.MA1 && check.MA2 && check.TX1 && check.TX2 && check.CA1 && check.CA2 && check.NY1 && check.NY2 && check.NY3){
clearTimeout(done.to);
done.to = setTimeout(function(){
expect(check.MA1).to.be('First');
expect(check.TX1).to.be('First');
expect(check.CA1).to.be('First');
expect(check.NY1).to.be('First');
expect(check.MA2).to.be('Second');
expect(check.TX2).to.be('Second');
expect(check.CA2).to.be('Second');
expect(check.NY2).to.be('Second');
expect(check.NY3).to.be('Third');
nopasstun(done, gun);
},10);
}
});
setTimeout(function(){
gun.get('NYCOUNT').put({NY3: "Third"});
},300);
});
});
it('once put once', function(done){
gun.get('opo').get('a').put('yay!');
var ref = gun.get('opo').get('a');
setTimeout(function(){
ref.once(function(data){
//console.log("************", data);
expect(data).to.be('yay!');
setTimeout(function(){
console.only(3, '.put z');
gun.get('opo').get('a').put('z');
setTimeout(function(){
ref.once(function(data){
//console.log("*+*+*+*+*+**+*+*");
expect(data).to.be('z');
nopasstun(done);
});
}, 25);
}, 25);
})
}, 25);
});
/*it('get recursive map', function(done){
var teams = {red: {}, blue: {}};
var alice = {age: 27, name: "Alice"};
var bob = {age: 29, name: "Bob"};
alice.spouse = bob;
bob.spouse = alice;
var carl = {age: 31, name: "Carl"};
teams.blue.alice = alice;
teams.blue.carl = carl;
teams.red.bob = bob;
teams.red.carl = carl;
console.only.i=1;console.log("===============");
Gun.statedisk(teams, 'gerema', function(ack){
console.log("VVVVVVVVVVVVVVVVVVV", ack);
setTimeout(function(){
gun.get('gerema').map().map().get('spouse').on(function(data){
console.only(2,'hi', data);
console.only(1,'hi', data);
console.log("*****************", data);return;
});
},500);});
});*/
it('get node after recursive field', function(done){
var bob = {age: 29, name: "Bob!"};
var cat = {name: "Fluffy", species: "kitty"};
var user = {bob: bob};
bob.pet = cat;
cat.slave = bob;
Gun.statedisk(user, 'nodecircle', function(){
//console.only.i=1;console.log("=============", gun);
//gun.get('nodecircle').get('bob').once(function(data){
gun.get('nodecircle').get('bob').get('pet').get('slave').once(function(data){
//console.log("*****************", data, done.to);return;
expect(done.to).to.not.be.ok();
done.to = setTimeout(function(){
expect(data.age).to.be(29);
expect(data.name).to.be("Bob!");
expect('string' == typeof Gun.valid(data.pet)).to.ok();
nopasstun(done);
},300);
});
});
});
it('recursive put', function(done){
//localStorage.clear();
var gun = Gun();
var parent = gun.get('parent');
var child = gun.get('child');
child.put({
way: 'down'
});
parent.get('sub').put(child);
//console.only.i=1;console.log("============================");
parent.get('sub').on(function(data){
//console.log("*********sub", data);
done.sub = data;
});
child.on(function(data){
done.child = data;
//console.log("*********child", data);
});
parent.on(function(data){
done.parent = data;
//console.log("*********parent", data);
if(done.c){ return } done.c = 1;
nopasstun(done, gun); // TODO: Add more meaningful checks!
});
});
it('empty val followed', function(done){
var gun = Gun();
gun.get('val/follow').once(function(data){
//console.log("val", data);
}).get(function(at){
//console.log("?????", at);
if(done.c){ return } done.c = 1;
nopasstun(done, gun);
});
});
it('map val get put', function(done){
var gun = Gun().get('chat/asdf');
var check = {}, count = {};
gun.map().once(function(v,f){
check[f] = v;
count[f] = (count[f] || 0) + 1;
//console.log("**************", f, v);
if(check['1-1'] && check['2-2']){
clearTimeout(done.to);
done.to = setTimeout(function(){
expect(check['1-1'].what).to.be('hi');
expect(check['2-2'].what).to.be('you.');
expect(count['1-1']).to.be(1);
expect(count['2-2']).to.be(1);
nopasstun(done, gun);
},50);
}
});
setTimeout(function(){
gun.get('1-1').put({what: "hi"});
setTimeout(function(){
gun.get('2-2').put({what: "you."});
},40);
},40);
});
it('get list set map simple', function(done){
var gun = Gun();
var list = gun.get('list-s');
list.set(gun.get('alice-s').put({name: "Alice", group: "awesome", married: true}));
var check = {}, count = {};
list.map().on(function(data, id){
expect(data.group).to.be('awesome');
expect(data.married).to.be(true);
expect(data.name).to.be('Alice');
nopasstun(done, gun);
});
});
it('get list set map val', function(done){
var gun = Gun();
var list = gun.get('list');
list.set(gun.get('alice').put({name: "Alice", group: "awesome", married: true}));
list.set(gun.get('bob').put({name: "Bob", group: "cool", married: true}));
list.set(gun.get('carl').put({name: "Carl", group: "cool", married: false}));
list.set(gun.get('dave').put({name: "Dave", group: "awesome", married: true}));
var check = {}, count = {};
list.map().once(function(data, id){
check[id] = data;
count[id] = (count[id] || 0) + 1;
if(check.alice && check.bob && check.carl && check.dave){
clearTimeout(done.to);
done.to = setTimeout(function(){
expect(count.alice).to.be(1);
expect(check.alice.name).to.be('Alice');
expect(check.alice.group).to.be('awesome');
expect(check.alice.married).to.be(true);
expect(count.bob).to.be(1);
expect(check.bob.name).to.be('Bob');
expect(check.bob.group).to.be('cool');
expect(check.bob.married).to.be(true);
expect(count.carl).to.be(1);
expect(check.carl.name).to.be('Carl');
expect(check.carl.group).to.be('cool');
expect(check.carl.married).to.be(false);
expect(count.dave).to.be(1);
expect(check.dave.name).to.be('Dave');
expect(check.dave.group).to.be('awesome');
expect(check.dave.married).to.be(true);
nopasstun(done, gun);
},50);
}
});
/*
Have we asked for this yet? No.
Do we have it cached? No.
Is its parent cached? Yes.
Reply immediately with that cache for map to process.
*/
/*
chain has a root // all
an ID // all
a back // all
inputs // all
and outputs // all
acks // any
echo // any
next // any
cache or map of many ones // only a one can have a cache, only a map can have many, and they must be ones. However any chain might have neither. By default a chain is a many, unless it is designated as a one.
gun.get('alice').also('bob').path('name').on(cb);
gun.get('users').map().path('friends').map().on(cb);
friends is a map, it has an echo
{name: "alice", friends: []}
{name: "xavier"}
{name: "yara"}
{name: "zack"}
{name: "bob", friends: []}
{name: "xavier"}
{name: "yara"}
{name: "zack"}
{name: "carl", friends: []}
{name: "xavier"}
{name: "yara"}
{name: "zack"}
*/
});
it('get get get set root get put', function(done){
var gun = Gun().get('app');
//console.only.i=1;console.log('---------------');
gun.get('alias').get('mark').set(
gun.back(-1).get('pub').put({
alias: 'mark',
auth: 'encrypt', // oops
born: 1,
pub: 'pub',
salt: 'random'
})
);
setTimeout(function(){
//console.debug.i=1;console.log('---------------');
gun.get(function(at){
//console.log("*", at.put);//return;
done.app = done.app || at.put.alias;
});
gun.back(-1).get('pub').get(function(at){
//console.log("**", at.put.auth);
done.pub = done.pub || at.put.auth;
});
gun.get('alias').get(function(at){
//console.log("***", at);
done.alias = done.alias || at.put.mark;
//!console.debug.i&&(console.debug.i=1)&&console.log("---------------------");
}).get('mark').on(function(data){
//console.log("************", data);//return;
clearTimeout(done.to);
done.to = setTimeout(function(){
done.mark = done.mark || data.pub;
//console.log('???', done.app, done.pub, done.alias);
expect(Gun.valid(done.mark)).to.be('pub');
expect(done.app).to.be.ok();
expect(done.pub).to.be.ok();
expect(done.alias).to.be.ok();
if(done.c){ return } done.c = 1;
nopasstun(done, gun);
},100);
})
},100);
});
it('get put get get put reload get get then get', function(done){
this.timeout(9000);
var gun = Gun();
gun.get('stef').put({name:'Stef'});
var address = {
country: 'Netherlands',
zip:'999999'
};
gun.get('stef').get('address').put(address);
// reload
setTimeout(function(){
var gun2 = Gun();
//console.log(require('fs').readFileSync('./radata/!').toString());
gun2.get('stef').get('address').once(function(data){ // Object {_: Object, country: "Netherlands", zip: "1766KP"} "address"
//console.log("******", data);return;
done.a = true;
expect(data.country).to.be('Netherlands');
expect(data.zip).to.be('999999');
if(!done.s){ return }
if(done.c){ return } done.c = 1;
nopasstun(done, gun2);
});
gun2.get('stef').once(function(data){ //Object {_: Object, address: Object} "stef"
//console.log("**************", data);return;
done.s = true;
expect(data.name).to.be('Stef');
expect(data.address).to.be.ok();
if(!done.a){ return }
if(done.c){ return } done.c = 1;
nopasstun(done, gun2);
});
},1200);
});
it('get get get any parallel', function(done){
Gun.statedisk({
bob: {
age: 29,
name: "Bob!"
}
}, 'parallel', function(){
gun.get('parallel').get('bob').get('age').get(function(at, ev){
var err = at.err, data = at.put, field = at.get;
//console.log("*****", field, data);return;
expect(data).to.be(29);
expect(field).to.be('age');
done.age = true;
});
//console.log("-----------------------");
gun.get('parallel').get('bob').get('name').get(function(at, ev){
var err = at.err, data = at.put, field = at.get;
//console.log("***********", field, data);return;
expect(data).to.be('Bob!');
expect(field).to.be('name');
done.name = true;
expect(done.age).to.be.ok();
if(done.c){ return } done.c = 1;
nopasstun(done, gun);
});
});
});
it('get get get any later', function(done){
Gun.statedisk({
bob: {_:{'#':'ddfsa'},
age: 29,
name: "Bob!"
}
}, 'parallel/later', function(){
gun.get('parallel/later').get('bob').get('age').get(function(at, ev){
var err = at.err, data = at.put, field = at.get;
//console.log("*****", field, data); return;
expect(data).to.be(29);
expect(field).to.be('age');
done.age = true;
});
setTimeout(function(){
gun.get('parallel/later').get('bob').get('name').get(function(at, ev){
var err = at.err, data = at.put, field = at.get;
//console.log("***********", field, data); return;
expect(data).to.be('Bob!');
expect(field).to.be('name');
done.name = true;
expect(done.age).to.be.ok();
if(done.c){ return } done.c = 1;
nopasstun(done, gun);
});
},400);
});
});
it('get get get any not', function(done){
gun.get('parallel/not').get('bob').get('age').get(function(at, ev){
var err = at.err, data = at.put, field = at.get;
//console.log("***** age", data);
expect(data).to.be(undefined);
expect(field).to.be('age');
done.age = true;
});
gun.get('parallel/not').get('bob').get('name').get(function(at, ev){
var err = at.err, data = at.put, field = at.get;
//console.log("*********** name", data);
expect(data).to.be(undefined);
expect(field).to.be('name');
done.name = true;
expect(done.age).to.be.ok();
if(done.c){return}done.c=1;
nopasstun(done, gun);
});
});
it('get get get any not later', function(done){
gun.get('parallel/not/later').get('bob').get('age').get(function(at, ev){
var err = at.err, data = at.put, field = at.get;
//console.log("***** age", data);
expect(data).to.be(undefined);
expect(field).to.be('age');
done.age = true;
});
setTimeout(function(){
//console.debug.i=1;console.log('---------------');
gun.get('parallel/not/later').get('bob').get('name').get(function(at, ev){
var err = at.err, data = at.put, field = at.get;
//console.log("*********** name", field, data);
expect(data).to.be(undefined);
expect(field).to.be('name');
done.name = true;
expect(done.age).to.be.ok();
if(done.c){ return } done.c = 1;
nopasstun(done, gun);
});
},400);
});
it('get any any', function(done){
Gun.statedisk({
hello: 'world',
goodbye: 'mars'
}, 'full', function(){
gun.get('full').get(function(at, ev){
var err = at.err, data = at.$._.put || at.put, field = at.get;
//console.log("*****1", data, field);return;
expect(data.hello).to.be('world');
expect(data.goodbye).to.be('mars');
});
gun.get('full').get(function(at, ev){
var err = at.err, data = at.$._.put || at.put, field = at.get;
//console.log("*****2", data, field);return;
expect(data.hello).to.be('world');
expect(data.goodbye).to.be('mars');
if(done.c){ return } done.c = 1;
nopasstun(done, gun);
});
});
});
it('get any any later', function(done){
Gun.statedisk({
hello: 'world',
goodbye: 'mars'
}, 'full/later', function(){
gun.get('full/later').get(function(at, ev){
var err = at.err, data = at.$._.put || at.put, field = at.get;
//console.log("*****", data);
expect(data.hello).to.be('world');
expect(data.goodbye).to.be('mars');
});
setTimeout(function(){
gun.get('full/later').get(function(at, ev){
var err = at.err, data = at.$._.put || at.put, field = at.get;
//console.log("*****2", field, data);
expect(data.hello).to.be('world');
expect(data.goodbye).to.be('mars');
if(done.c){ return } done.c = 1;
nopasstun(done, gun);
});
},400);
});
});
it('multiple times map', function(done){
var gun = Gun();
gun.get('A').put({
'B': {
C: {
pub: 'fdsa',
y: "mark"
}
},
'timber': {
asdf: {
pub: 'asdf',
name: "timber"
}
}
});
var check = {on: {}, once: {}};
setTimeout(function(){
//console.log('A=2, map=7, map.map=8, A.B=3, AB=5, A.B.C=4, ABC=6, AB.C=?', gun);
gun.get('A').map().map().on(function(data, key){
//console.log(111111, key, data);
check.on[data.pub] = true;
})
}, 900);
setTimeout(function(){
gun.get('A').map().map().once(function(data, key){
//console.log(22222, key, data);
check.once[data.pub] = true;
//console.log(check);
if(check.on['asdf'] && check.on['fdsa'] && check.once['asdf'] && check.once['fdsa']){
if(done.c){ return } done.c = 1;
nopasstun(done, gun);
}
})
}, 1200);
});
it('many maps with @rogowski!', function(done){
var gun = Gun();
var data = {
levelA2: { levelA3: { levelA4: { levelA5: "hello" } } },
levelB2: { levelB3: { levelB4: { levelB5: "world" } } }
};
Gun.statedisk(data, 'level1', function(){
var check = {}, log = function(){} || console.log;
gun.get('level1').on(function(v,k){ log(1,k,v); check[k] = v });
gun.get('level1').map().on(function(v,k){ log('*',2,k,v); check[k] = v });
gun.get('level1').map().map().on(function(v,k){ log('*',3,k,v); check[k] = v });
gun.get('level1').map().map().map().on(function(v,k){ log('*',4,k,v); check[k] = v;
check.to = check.to || setTimeout(function(){
expect(check.level1.levelA2).to.eql({'#':"level1/levelA2"});
expect(check.level1.levelB2).to.eql({'#':"level1/levelB2"});
expect(check.levelA2.levelA3).to.eql({'#':"level1/levelA2/levelA3"});
expect(check.levelA3.levelA4).to.eql({'#':"level1/levelA2/levelA3/levelA4"});
expect(check.levelA4.levelA5).to.be("hello");
expect(check.levelB2.levelB3).to.eql({'#':"level1/levelB2/levelB3"});
expect(check.levelB3.levelB4).to.eql({'#':"level1/levelB2/levelB3/levelB4"});
expect(check.levelB4.levelB5).to.be("world");
nopasstun(done, gun);
}, 250);
});
gun.get('level1').map().map().map().map().on(function(v,k){ log('*',5,k,v); check[k] = v; }); // see test below
}, 1000);
});
it('many maps with @rogowski last value map', function(done){
var gun = Gun();
var data = {
levelA2: { levelA3: { levelA4: { levelA5: "hello" } } },
levelB2: { levelB3: { levelB4: { levelB5: "world" } } }
};
Gun.statedisk(data, 'level1p', function(){
var check = {}, log = function(){} || console.log;
//console.log("======================");
gun.get('level1p').map().map().map().map().on(function(v,k){ log('level5', k,v); check[k] = v;
check.to = check.to || setTimeout(function(){
expect(check.levelA5).to.be('hello');
expect(check.levelB5).to.be('world');
nopasstun(done, gun);
}, 20);
});
}, 1000);
});
it('multiple map test with @rogowski!', function(done){
var check = {};
var gun1 = Gun();
gun1.get('mmA').put({
'B': {
C: {
pub: 'fdsa',
y: "mark"
}
},
'timber': {
asdf: {
pub: 'asdf',
name: "timber"
}
}
});
//console.only.i=1;console.log("--------------------", gun1._.next);
gun1.get('mmA').map().map().on(function(data, has){
check[has+1] = data;
//console.log('first test ONLY get called with C/asdf = pub:fdsa/pub:asdf......', has, data);
});
setTimeout(function(){
var gun2 = Gun();
gun2.get('2mmA').put({nest: {
'B': {
C: {
pub: 'fdsa',
y: "mark"
}
},
'timber': {
asdf: {
pub: 'asdf',
name: "timber"
}
}
}});
//console.only.i=101;console.log("------------------");
//console.log("CHAIN ID: 2mma = 2, 2mmA.nest = 3, map=4, map.map=5, 2mmaNBC=17, 2mma.nest.b.c=8, 2mmanest=9, 2mmanest.b=11", gun2._);
gun2.get('2mmA').get('nest').map().map().on(function(data, has){
check[has+2] = data;
//console.log('should log pub=fdsa/asdf....', has, data);
check.to = check.to || setTimeout(function(){
if(check.C1.pub === 'fdsa' && check.C1.y === 'mark'
&& check.asdf1.pub === 'asdf' && check.asdf1.name === 'timber'
&& check.C2.pub === 'fdsa' && check.C2.y === 'mark'
&& check.asdf2.pub === 'asdf' && check.asdf2.name === 'timber'){
nopasstun(done, gun2);
}
}, 150);
});
},70);
});
it('multiple times', function(done){
var gun = Gun();
var app = gun.get('mult/times');
app.get('alias').get('mark').set(gun.get('ASDF').put({
pub: 'ASDF',
alias: 'mark',
born: 1
}));
gun.get('mult/times').get('alias').map().map().get('pub').on(foo);
function foo(data){
done.one = done.one || data;
if(!done.one || !done.two){ return }
expect(done.one).to.be("ASDF");
expect(done.two).to.be("mark");
if(done.c){ return } done.c = 1;
nopasstun(done, gun);
};
setTimeout(function(){
app.get('alias').map().map().get('alias').on(function(data){
done.two = data;
foo();
});
},10);
});
it('multiple times partial', function(done){
Gun.statedisk({ alias: { mark: { pub: {_:{'#':'PUB'}, pub: 'asdf', alias: 'mark', born: 1 } } } }, 'mult/times/part', function(){
var gun = Gun();
var app = gun.get('mult/times/part');
//console.debug.i=1;console.log("===================");
// app.get('alias').get('mark').once(function(alias){
// console.log("***111 ", alias);
// done.alias = alias;
// });
app.get('alias').get('mark').map().once(function(alias){
// console.log("***>>>> ", alias);
// if (typeof alias !== 'undefined') {
done.alias = alias;
// }
});
setTimeout(function(){
app.get('alias').map().map().get('born').on(function(data){
// console.log("*******", data);
expect(data).to.be(1);
expect(done.alias.pub).to.be("asdf");
expect(done.alias.alias).to.be("mark");
expect(done.alias.born).to.be(1);
if(done.c){ return } done.c = 1;
nopasstun(done, gun);
});
},400);
}, 1000);
});
it('put on a put', function(done){
try{
var gun = Gun();
var foo = gun.get('put/on/put').get('a').get('b');
var bar = gun.get('put/on/put/ok').get('a').get('b');
bar.put({a:1});
//console.log("vvvvvvvvv");
bar.on(function(data){
//console.log("***", data);
if(1 === data.a && 3 === data.c){
if(done.c){ return } done.c = 1;
//console.log("-------");
nopasstun(done, gun);
}
});
foo.on(function(ack){
//console.log("*", ack);
bar.put({c:3});
});
foo.put({b:2});
}catch(e){ console.log("!!!!!!!!!!!", e)}
});
it('map with map function', function(done){
var gun = Gun(), s = 'map/mapfunc', u;
var app = gun.get(s);
var list = app.get('list');
var check = {};
list.map(function(user){ /*console.log("****", user);*/ return user.age === 27? user.name + "thezombie" : u }).on(function(data){
//console.log('+++++', data);
check[data] = true;
if(check.alicethezombie && check.bobthezombie){
if(done.c){return}done.c=1;
setTimeout(function(){ nopasstun(done, gun) },99);
}
});
//console.debug.i=1;console.log("--------------");
list.set({name: 'alice', age: 27}); // on put, table-scan flag doesn't get set, but is needed for initial!??
list.set({name: 'bob', age: 27});
list.set({name: 'carl', age: 29});
list.set({name: 'dave', age: 25});
});
it('once map function once', function(done){
var gun = Gun(), s = 'o/mf/o', u;
var app = gun.get(s);
var list = app.get('list');
var check = {};
gun.get('useromo').get('alice').put({name:'Alice', email:'alice@example.com'})
gun.get('useromo').get('bob').put({name:'Bob', email:'bob@example.com'})
gun.get('useromo').get('carl').put({name:'Carl', email:'carl@example.com'})
gun.get('useromo').once().map(v => {
//console.log('this gets called', v);
return v
}).once((v, k) => {
//console.log('this is never called', k, v);
check[k] = (check[k] || 0) + 1;
if(1 === check.alice && 1 === check.bob && 1 === check.carl){
if(done.c){return}done.c=1;
setTimeout(function(){ nopasstun(done, gun) },9);
}
});
});
it('val and then map', function(done){
var gun = Gun(), s = 'val/then/map', u;
var list = gun.get(s);
list.set(gun.get('alice').put({name: 'alice', age: 27}));
list.set(gun.get('bob').put({name: 'bob', age: 27}));
list.set(gun.get('carl').put({name: 'carl', age: 29}));
list.set(gun.get('dave').put({name: 'dave', age: 25}));
var check = {};
list.once().map().on(function(data, key){
check[key] = data;
clearTimeout(done.to);
//console.log("*****", key, data);
done.to = setTimeout(function(){
if(check.alice && check.bob && check.carl && check.dave && done.last){
expect(check.alice.age).to.be(27);
expect(check.bob.age).to.be(28);
expect(check.carl.age).to.be(29);
expect(check.dave.age).to.be(25);
expect(check.eve).to.not.be.ok();
if(done.c){return}done.c=1;
setTimeout(function(){ nopasstun(done, gun) },9);
}
},600);
});
setTimeout(function(){
list.set(gun.get('eve').put({name: 'eve', age: 30}));
gun.get('bob').get('age').put(28);
done.last = true;
},300);
});
it('check null on map', function(done){
var list = gun.get('myList');
list.map(function(value, id){
if("hello world" === value){
done.one = true;
}
if(null === value){
done.two = true;
}
if(done.one && done.two){
if(done.c){ return } done.c = 1;
nopasstun(done, gun);
}
});
list.get('message').put('hello world'); // outputs "message: hello world"
list.get('message').put(null); // throws Uncaught TypeError: Cannot read property '#' of null
});
it('Check multi instance message passing', function(done){
// NOTICE: The behavior of this test changed from v0.2020.520 to version after.
try{ require('fs').unlinkSync('bdata') }catch(e){}
try{ require('fs').unlinkSync('ddata') }catch(e){}
Gun.on('opt', function(ctx){
ctx.on('out', function(msg){
this.to.next(msg);
var onGun = ctx;
var tmp = {}; Object.keys(msg).forEach(function(k){ tmp[k] = msg[k] }); delete tmp.out; delete tmp._; msg = tmp; // copy message.
if(onGun.$ === b) {
if(d){
//console.log("b can send to d....", JSON.parse(JSON.stringify(msg)));
msg.$ = d;
d.on("in", msg);
}
} else if(onGun.$ === d){
//console.log("d sends to b....", JSON.parse(JSON.stringify(msg)));
msg.$ = b;
b.on("in", msg);
}
});
});
var b = Gun({file: "bdata"});
var d = null;
var bb = b.get("key");
bb.put({msg: "hello"});
d = Gun({file: "ddata"});
var db = d.get("key");
db.map().on(function(val,field){
expect(val).to.be('hello');
if(done.c){ return } done.c = 1;
setTimeout(function(){
nopasstun(0, b);
nopasstun(done, d);
},1700);
});
});
it('val should now get called if no data is found', function(done){
var gun = Gun();
gun.get('nv/foo').get('bar').get('baz').once(function(val, key){
//console.log('*******', key, val);
expect(val).to.be(undefined);
done.fbb = true;
});
gun.get('nv/totesnothing').once(function(val, key){
//console.log('***********', key, val);
expect(val).to.be(undefined);
done.t = true;
});
gun.get('nv/bz').get('lul').once(function(val, key){
//console.log('*****************', key, val);
expect(val).to.be(undefined);
done.bzl = true;
setTimeout(function(){
if(done.fbb && done.t && done.bzl){
if(done.c){ return } done.c = 1;
nopasstun(done, gun);
}
},100);
});
});
it('Callbacks should have database safe data copies', function(done){
var gun = Gun();
gun.get('ds/safe').put({a: 1});
gun.get('ds/safe').on(function(data){
data.b = 2;
});
gun.get('ds/safe').once(function(data){
expect(gun.back(-1)._.graph['ds/safe'].b).to.not.be.ok();
if(done.c){ return } done.c = 1;
nopasstun(done, gun);
});
});
it('If chain cannot be called, ack', function(done){
Gun.statedisk({ wat: 1, a: true }, 'nl/app', function(){
var gun = Gun(), u;
var app = gun.get('nl/app');
app.get(function(d){
if(done.a){ return }
d = (d.$$||d.$)._.put;
//console.log('*', d);
expect(d.wat).to.be(1);
expect(d.a).to.be(true);
done.a = 1;
}, {v2020:1});
app.get('a').get('b').get(function(d){
d = (d.$$||d.$)._.put;
//console.log('****', d);
expect(d).to.be(u);
expect(done.a).to.be.ok();
done.b = (done.b || 0) + 1;
}, {v2020:1});
setTimeout(function(){ // adding more rigorous test!
//console.log("------------");
app.get('a').get('b').get(function(d){
d = (d.$$||d.$)._.put;
//console.log('****::::', d);
expect(done.b).to.be(1);
done.c = (done.c || 0) + 1;
});
app.get('a').put('lol');
setTimeout(function(){
expect(done.c).to.be(1);
if(done.d){ return } done.d = 1;
nopasstun(done, gun);
},50);
}, 50);
}, 1000);
});
it('Chain on known nested object should ack', function(done){
Gun.statedisk({ bar: { wat: 1 } }, 'nl/app', function(){
var gun = Gun(), u;
var app = gun.get('nl/app').get('bar');
app.get(function(d){
//d = (d.$$||d.$)._.put;
if(!d || !d.put || !d.put.wat){ return }
//console.log('************ should be called: {wat:1}=', d.put);
expect(d.put.wat).to.be(1);
done.a = 1;
if(!done.u){ return }
expect(done.u).to.be.ok();
if(done.c){ return } done.c = 1;
nopasstun(done, gun);
});//, {v2020:1});
//console.log("----------");
app.get('a').get('b').get(function(d){
//console.log("************ empty/clear: undefined=", d.put);
//d = (d.$$||d.$)._.put;
expect(d.put).to.be(u);
done.u = true;
if(!done.a){ return }
expect(done.a).to.be.ok();
if(done.c){ return } done.c = 1;
nopasstun(done, gun);
}, {v2020:1});
}, 1000);
});
it('Soul above but not beneath', function(done){
this.timeout(5000);
var gun = Gun();
var a = gun.get('sabnb');
a.get('profile').put({_:{'#': 'sabnbprofile'}, name: "Plum"});
setTimeout(function(){
a.get('profile').get('said').get('asdf').put('yes');
setTimeout(function(){
a.once(function(data){
expect(data.profile).to.be.eql({'#': 'sabnbprofile'});
if(done.c){ return } done.c = 1;
nopasstun(done, gun);
})
}, 100);
}, 100);
});
it('users map map who said map on', function(done){
this.timeout(1000 * 9);
var gun = Gun();
gun.get('users/mm').put({
alice: {_:{'#':'alias/alice'},
'pub/asdf': {_:{'#':'pub/asdf'},
pub: 'asdf'
}
},
bob: {_:{'#':'alias/bob'},
'pub/fdsa': {_:{'#':'pub/fdsa'},
pub: 'fdsa'
}
}
});
var check = {}, c = 0, end;
//console.log(check, gun._.graph);
gun.get('users/mm').map().map()
.get('who').get('said').map().on(function(msg){
//console.log("------>", msg);
if(check[msg.num]){
//console.log("!!!!", msg.num, "!!!!");
}
delete check[msg.num];
c++;
clearTimeout(end); end = setTimeout(function(){
//console.log("?", c, check, Object.keys(check), gun._.graph);
if(!Object.empty(check)){ return } //if(Gun.obj.map(check, function(v){ if(v){ return v } })){ return }
nopasstun(done, gun);
},9);
});
var said = gun.get('pub/asdf').get('who').get('said');
function run(i){
//if(i > 1){ return } // DEBUGGING!
//console.log("----", i, "----");
//2 === i && (console.only.i = 1) && console.only(1, '==========');
//(console.debug.i = console.debug.i || 1);
said.set({
what: i + " Hello world!",
num: i,
who: 'asdf',
id: 'alice',
});
}
var i = 0, m = 9, to = setTimeout(function frame(){
if(m <= i){
clearTimeout(to);
return;
}
i++;
check[i] = true;
run(i);
setTimeout(frame, 1);
}, 1);
});
it('get map should not slowdown', function(done){
this.timeout(9000);
var gun = Gun({test_no_peer:true}).get('g/m/no/slow');
//console.log("---------- setup data done -----------");
var prev, diff, max = 90, total = 500, largest = -1, gone = {}, u;
//var prev, diff, max = Infinity, total = 10000, largest = -1, gone = {};
// TODO: It would be nice if we could change these numbers for different platforms/versions of javascript interpreters so we can squeeze as much out of them.
gun.get('history').map().on(function(time, index){
diff = +new Date - time;
//console.log(">>>", index, time, diff);//return;
expect(gone[index]).to.not.be.ok();
gone[index] = diff;
largest = (largest < diff)? diff : largest;
expect(diff > max).to.not.be.ok();
});
//console.only.i=1;
var turns = 0;
var many = setTimeout(function go(){ // TODO: NOTE: BUG? using setInterval caused poor CPU scheduling that did fail this test, it is possible actual apps might use that approach even tho for now they should use this adjusted version, so maybe we need to review a test in future for that?
if(turns > total || (diff || 0) > (max + 5)){
if(u === diff){ return }
clearTimeout(many);
expect('number' === typeof diff).to.be.ok();
if(done.c){ return } done.c = 1;
nopasstun(done, gun);
return;
}
prev = +new Date;
var put = {}; put[turns += 1] = prev;
//console.log("put", put);
//console.log("------", turns, "-------");
//3 === turns && (console.debug.i = 1);
//console.debug(1, 'save', {history: put});
gun.put({history: put});
many = setTimeout(go, 1); // see above NOTE, increasing total runs to compensate.
}, 1);
});
it('Check put callback', function(done){
var gun = Gun();
gun.get('c/p/c').get('a').put('lol', function(ack){
nopasstun(done, gun);
});
});
it('Resume reads after put error', function(done){
var gun = Gun();
gun.get('r/r/a/p/e').put({a: 1});
setTimeout(function(){
gun.get('r/r/a/p/e').get('a').get('b').get('c').put([], function(ack){
expect(ack.err).to.be.ok();
expect(ack.err.toLowerCase().indexOf('array') >= 0).to.be.ok();
expect(ack.err.toLowerCase().indexOf('a.b.c') >= 0).to.be.ok();
setTimeout(function(){
gun.get('r/r/a/p/e').once(function(data){
expect(data.a).to.be(1);
//console.log("data!", data);
nopasstun(done, gun);
});
},50);
});
},100)
});
it('Multiple subscribes should trigger', function(done){
// thanks to @ivkan for reporting and providing test.
var gun = Gun();
var check = {};
gun.get('m/s/key').put({property: 'value'});
gun.get('m/s/key').on(function(data, key){
check['a'+data.property] = 1;
});
gun.get('m/s/key').on(function(data, key){
check['b'+data.property] = 1;
if(check.avalue && check.bvalue && check.anewValue && check.bnewValue){
if(done.c){ return } done.c = true;
nopasstun(done, gun);
}
});
setTimeout(function(){
gun.get('m/s/key').put({property: 'newValue'});
}, 1000);
});
it('Deep puts with peer should work', function(done){
// tests in async mode now automatically connect to localhost peer.
//var gun = Gun('http://localhost:8765/gun');
var gun = Gun();
//var user = gun.user();
//user.create('alice', 'password', function(){
gun.get('who').get('all').put({what: "hello world!", when: Gun.state()}, function(ack){
//user.get('who').get('all').put({what: "hello world!", when: Gun.state()}, function(ack){
gun.get('who').get('all').once(function(data){
expect(data.what).to.be.ok();
expect(data.when).to.be.ok();
nopasstun(done, gun);
});
});
//});
});
it('Set a ref should be found', function(done){
var gun = Gun();
var msg = {what: 'hello world'};
//var ref = user.get('who').get('all').set(msg);
//user.get('who').get('said').set(ref);
var ref = gun.get('s/r/who').get('all').set(msg, function(ack){ /*console.log('@@@', ack)*/ });
gun.get('s/r/who').get('said').set(ref, function(ack){ /*console.log('###', ack)*/ });
gun.get('s/r/who').get('said').map().once(function(data){
expect(data.what).to.be.ok();
nopasstun(done, gun);
})
});
/*describe('talk to live server tests', function(){
this.timeout(1000 * 9);
it.only('Second once on undefined should call', function(done){ // this test is passing when it fails by hand?
var gun = Gun('https://gunjs.herokuapp.com/gun');
gun.get('~@O8H2BJa4pNfecWamWN7efd888Pg1@hackernoon').once(function(data){
console.log(1, data);
expect(data).to.not.be.ok();
setTimeout(function(){
gun.get('~@O8H2BJa4pNfecWamWN7efd888Pg1@hackernoon').once(function(data){
console.log(2, data);
expect(data).to.not.be.ok();
done();
});
}, 3000);
});
});
});*/
it('Nested listener should be called', function(done){
var gun = Gun();
/*
var app = gun.get('nl/app').get('bar');
app.on(function(d){
console.log("!!", d);
})
app.put({wat: 1});
console.debug.i=1;console.log("------------");
console.log(gun._.now);
app.put({a: {b:2}});
console.log('_______________________');
return;*/
var app = gun.get('nl/app');
var node = app.get('watcher/1').put({"stats":{"num":3},"name":"trex"});
var C = 0;
app.get('watcher/1').get('stats').on(function (v, k) {
if(++C === 1){
expect(v.num).to.be(3);
return;
}
expect(v.num).to.be(4);
if(done.c){ return } done.c = 1;
nopasstun(done, gun);
});
//return;
setTimeout(function(){
app.get('watcher/1').put({"stats":{"num":4},"name":"trexxx"});
},100);
});
//return;
it.skip('do not refire', function(done){ // for Wasis @yokowasis ! Thanks for finding.
var gun = Gun();
for (i=0;i<=100;i++) {
gun.get("something").get("level1").put({
[i]: i
})
}
for (i=0;i<=100;i++) {
gun.get("something").get("level1").get("level2").put({
[i]: i
})
}
var c = 0;
setTimeout(function(){
gun.get("something").get("level1").on(()=>{
c++;
});
setTimeout(function(){
gun.get("something").get("level1").once(function(x){
setTimeout(function(){
expect(c).to.be(1);
nopasstun(done, gun);
},100);
});
},100);
},100);
});
/*it.skip('Memory management', function(done){
this.timeout(9999999);
var gun = Gun(), c = 100000, big = "big";
while(--c){big += "big"}
c = 0;
setInterval(function(){
var key = Gun.text.random(5);
gun.get(key).put({data: big});
setTimeout(function(){
gun.get(key).off();
},10);
if(typeof process === 'undefined'){ return }
var mem = process.memoryUsage();
console.log(((mem.heapUsed / mem.heapTotal) * 100).toFixed(0) + '% memory');
console.log(Object.keys(gun._.graph).length, 'item in memory graph:', Object.keys(gun._.graph));
},25);
});
it('Custom extensions are chainable', function(done){
Gun.chain.filter = function(filter){
var chain = this.chain();
var context = this;
var _tags;
context.once(function(obj, key){
if(!obj.tags){
console.warn('Not tagged to anything!');
context._.valid = false;
chain._.on('in', {get: key, $: this});
return false;
} else {
_tags = Gun.obj.ify(obj.tags);
if(Array.isArray(filter)){
context._.valid = filter.every(function(f){ return ( _tags[f] && _tags[f]==1) });
if(context._.valid){
chain._.on('in', {get: key, put: obj, $: this});
return context;
} else {
console.log("that was wrong");
chain._.on('in', {get: key, put: undefined, $: this});
}
return false;
} else {
console.warn('filter should be an Array');
return false;
}
}
});
return chain;
}
var gun = Gun();
var fake1 = gun.get('fake1').put({name:'faker1',tags:JSON.stringify({a:1,b:0,c:1})});
var fake2 = gun.get('fake2').put({name:'faker2',tags:JSON.stringify({a:1,b:1,c:1})});
var list = gun.get('list');
list.set(fake1);
list.set(fake2);
gun.get('fake1')//.map()
.filter(['a','b']) // Gun.chain.filter = function(tags){ .... }
.get(function(no){console.log("NO!", no)})
.once(function(yes){console.log("YES!", yes)})
}); */
it('Check that events are called with multiple instances', function(done){
var gunA = Gun( { file : "A.json" } );
var gunB = Gun( { file : "B.json" });
var gunC = Gun( { file : "C.json" });
var check = {};
gunA.get( "some path A" ).map(function(v,f){ check.A = v; /*console.log( "event on A: ", f, v )*/ } );
gunB.get( "some path B" ).map(function(v,f){ check.B = v; /*console.log( "event on B: ", f, v )*/ } );
gunC.get( "some path C" ).map(function(v,f){ check.C = v; /*console.log( "event on C: ", f, v )*/ } );
gunA.get( "some path A" ).put( { simple:"message" } );
gunB.get( "some path B" ).put( { simple:"message" } );
gunC.get( "some path C" ).put( { simple:"message" } );
setTimeout(function(){
expect(check.A).to.be('message');
expect(check.B).to.be('message');
expect(check.C).to.be('message');
nopasstun(0, gunA);
nopasstun(0, gunB);
nopasstun(done, gunC);
}, 100);
});
it('ack aggregation bypass', function(done){
console.log("WORKS IN BROWSER, NOT SURE WHY NODEJS CONFUSED, CHECK LATER");
done();return;
var alice = Gun({localStorage: false, file: false, rad: false, radisk: false});
var bob = Gun({localStorage: false, file: false, rad: false, radisk: false});
var carl = Gun({localStorage: false, file: false, rad: false, radisk: false});
var adam = alice.back('opt.mesh');
var asay = adam.say;
var bdam = bob.back('opt.mesh');
var bsay = bdam.say;
var cdam = carl.back('opt.mesh');
var csay = cdam.say;
//console.only.i = 1;
adam.say = function(raw, peer){
console.only(2, 'adam says:', raw);
console.only(1, '...');
bdam.hear((raw.length && raw) || JSON.stringify(raw), {});
asay(raw, peer);
}
bdam.say = function(raw, peer){
console.only(7, "bob the relay is like YO", raw);
adam.hear((raw.length && raw) || JSON.stringify(raw), {});
cdam.hear((raw.length && raw) || JSON.stringify(raw), {});
bsay(raw, peer);
}
cdam.say = function(raw, peer){
console.only(4, "carl speaks out:", raw);
console.only(3, "...");
bdam.hear((raw.length && raw) || JSON.stringify(raw), {});
csay(raw, peer);
}
carl.on('put', async function(msg){
this.to.next(msg);
var tmp = msg.put;
//if(Math.random() > 0.5){ return; }
//console.log(msg.put);
//localStorage[tmp['#']+tmp['.']] = tmp[':'];
setTimeout(function(){
carl.on('out', {'@': msg['#']+'', ok: {BANANA: 9}});
}, 10);
});
alice.on('get', function(msg){ setTimeout(function(){ Gun.on.get.ack(msg); },9) })
setTimeout(async function(){
var pair = await SEA.pair();
var user = alice.user();
setTimeout(function(){
var c = 0;
//alice.on('auth', function(){
alice.get('test').put({a: 1, b: 2, c: 3}, function(ack){
//console.log("my data got saved?", ack);
if(ack.ok.BANANA && ++c === c){
done();
}
}, {acks: 99});
//}); user.auth(pair);
},10);
}, 100);
});
/*it.only('Make sure circular contexts are not copied', function(done){
//let's define an appropriate deep default database...
var dfltSansUsers = { 1: { name : "org1", sites : { 1: {name : "site1"} } } };
var alice = {name: "alice" }
var gun = Gun();
var root = gun.get( "root" );
root.put( dfltSansUsers );
var alice = gun.get( "alice" ).put( { name: "alice" } );
console.log( "Failed after this" );
root.get("1").get("sites").get("1").get("users" ).put( { 1: alice } );
console.log( "Failed before this" );
});*/
it('get any any none', function(done){
gun.get('full/none').get(function(at, ev){
var err = at.err, data = at.put, field = at.get;
//console.log("*****", data);
expect(data).to.be(undefined);
});
gun.get('full/none').get(function(at, ev){
var err = at.err, data = at.put, field = at.get;
//console.log("*****2", data);
expect(data).to.be(undefined);
if(done.c){ return } done.c = 1;
nopasstun(done, gun);
});
});
it('get any any none later', function(done){
gun.get('full/none/later').get(function(at, ev){
var err = at.err, data = at.put, field = at.get;
//console.log("*****", data);
expect(data).to.be(undefined);
});
setTimeout(function(){
gun.get('full/none/later').get(function(at, ev){
var err = at.err, data = at.put, field = at.get;
//console.log("*****2", data);
expect(data).to.be(undefined);
nopasstun(done, gun);
});
},400);
});
it('get get any parallel', function(done){
Gun.statedisk({ bob: { age: 29, name: "Bob!" } }, 'parallel/get/get', function(){
gun.get('parallel/get/get').get('bob').get(function(data){ data = data.put;
//console.log("***** 1", data);
expect(data.age).to.be(29);
expect(data.name).to.be('Bob!');
});
gun.get('parallel/get/get').get('bob').get(function(data){ data = data.put;
//console.log("***** 2", data);
expect(data.age).to.be(29);
expect(data.name).to.be('Bob!');
if(done.c){ return } done.c = 1;
nopasstun(done, gun);
});
}, 1000);
});
it('once on link to nothing @mimiza', function(done){
gun.get('oltn').put({"#": "this-does-not-exist"})
gun.get('oltn').once(response => {
//console.log('did we call?', response) ;
expect(response).to.not.be.ok();
nopasstun(done, gun);
})
});
it('once on link to nothing deep @mimiza', function(done){
gun.get('oltnd').get('deep').put({"#": "this-does-not-exist"})
gun.get('oltnd').get('deep').once(response => {
//console.log('did we call?', response) ;
expect(response).to.not.be.ok();
nopasstun(done, gun);
})
});
return;
it('get get any parallel later', function(done){
Gun.statedisk({ bob: { age: 29, name: "Bob!" } }, 'parallel/get/get/later', function(){
gun.get('parallel/get/get/later').path('bob').any(function(err, data, field, at, ev){
//console.log("***** 1", data);
expect(data.age).to.be(29);
expect(data.name).to.be('Bob!');
});
setTimeout(function(){
gun.get('parallel/get/get/later').path('bob').any(function(err, data, field, at, ev){
//console.log("***** 2", data);
expect(data.age).to.be(29);
expect(data.name).to.be('Bob!');
done();
});
},400);
}, 1000);
});
it('get get any none', function(done){
Gun.statedisk({ alice: { age: 31, name: "alice" } }, 'get/get/none', function(){
var c = 0, s = 0;
gun.get('get/get/none').path('bob').any(function(err, data, field, at, ev){
//console.log("***** 1", data);
c++;
s = 0;
expect(data).to.be(undefined);
});
s = 1;
gun.get('get/get/none').path('bob').any(function(err, data, field, at, ev){
//console.log("***** 2", data);
c++;
//if(s){ c++ } // TODO: Talk to Jesse about this.
expect(data).to.be(undefined);
if(2 === c){ // We want 2 replies for each `any`, once from LS replying with the soul (but not the field), and once from WSP replying that the soul couldn't be found.
// Wrong! I think we've changed this, such that lS handles it alone and not WSP.
done();
}
});
}, 1000);
});
it('get get any none later', function(done){
Gun.statedisk({ alice: { age: 31, name: "alice" } }, 'get/get/none/later', function(){
var c = 0;
gun.get('get/get/none/later').path('bob').any(function(err, data, field, at, ev){
//console.log("***** 1", data);
c++;
expect(data).to.be(undefined);
});
setTimeout(function(){
gun.get('get/get/none/later').path('bob').any(function(err, data, field, at, ev){
//console.log("***** 2", data);
c++;
expect(data).to.be(undefined);
//if(3 === c){ // Because we already have active listeners cached waiting for data to pipe in, BUT we have already received multiple responses that the data isn't found, the "not found" is cached and so we get an immediate response just from cache. If later data does get piped in, this will still get called.
done();
//}
});
},400);
}, 1000);
});
it('get get primitive get any', function(done){
Gun.statedisk({ bob: "is awesome" }, 'get/get/prim', function(){
gun.get('get/get/prim').path('bob').path('age').any(function(err, data, field, at, ev){
//console.log("***** 1", data);
expect(data).to.be(undefined);
});
gun.get('get/get/prim').path('bob').path('age').any(function(err, data, field, at, ev){
//console.log("***** 2", data);
expect(data).to.be(undefined);
done();
});
}, 1000);
});
it('get put any', function(done){
Gun.statedisk({ here: "we go" }, 'get/put/any', function(){
//console.debug.i=1;console.log("---------------");
gun.get('get/put/any')
.put({})
.any(function(err, data, field, at, ev){
//console.log("***** 1", data);
done();
});
}, 1000);
});
return;
it('get any, get put any', function(done){
Gun.statedisk({ here: "we go" }, 'get/any/get/put/any', function(){
gun.get('get/any/get/put/any')
.any(function(err, data, field, at, ev){
if(done.first){ return } // it is okay for `any` to get called multiple times.
//console.log("***** 1", data);
expect(data.here).to.be('we go');
if(done.first){
expect(data.yes).to.be('please');
}
done.first=1;
});
setTimeout(function(){
gun.get('get/any/get/put/any')
.put({yes: 'please'})
.any(function(err, data, field, at, ev){
if(done.second){ return } // it is okay for `any` to get called multiple times.
//console.log("***** 2", data);
expect(data.here).to.be('we go');
expect(data.yes).to.be('please');
done();
done.second = 1;
});
},400);
}, 1000);
});
it('mutate pointer to primitive deep on', function(done){
Gun.statedisk({ bob: { age: 29, name: "Bob!", pet: { name: "Fluffy", species: "kitty" } } }, 'change/pointer', function(){
gun.get('change/pointer').path('bob').path('pet').any(function(err, data, f, at, ev){
//console.log("***", data);return setTimeout(function(){asdf},500);
if(done.c){
expect(data).to.be(undefined);
return;
}
expect(data.name).to.be('Fluffy');
expect(data.species).to.be('kitty');
done.c = 1;
});
setTimeout(function(){
gun.get('change/pointer').put({
bob: null
});
setTimeout(function(){
gun.get('change/pointer').put({
bob: "hello!"
});
},400);
},400);
gun.get('change/pointer').any(function(err, data){
//console.log("****************", data);
if(2 <= done.e && data.bob){
expect(data.bob).to.be('hello!');
done();
return;
}
if(1 <= done.e){
expect(data.bob).to.be(null);
done.e = 2;
return;
}
expect(Gun.val.link.is(data.bob)).to.be.ok();
done.e = 1;
});
}, 1000);
});
it('get only soul', function(done){
Gun.statedisk({ bob: { age: 29, name: "Bob!", pet: { name: "Fluffy", species: "kitty" } } }, 'only/soul', function(){
gun.get('only/soul')/*.path('bob')*/.any(function(err, data){
expect(Gun.obj.empty(data, '_')).to.be.ok();
done();
}, {'.': null});
}, 1000);
});
it('get path only soul', function(done){
Gun.statedisk({ bob: { age: 29, name: "Bob!", pet: { name: "Fluffy", species: "kitty" } } }, 'only/p/soul', function(){
gun.get('only/p/soul').path('bob').any(function(err, data){
//console.log("*********", err, data);
expect(Gun.val.link.is(data)).to.be.ok();
//expect(Gun.obj.empty(data, '_')).to.be.ok();
done();
}, {'.': null});
}, 1000);
});
it('mutate pointer to self', function(done){
Gun.statedisk({ bob: { age: 29, name: "Bob!", pet: { name: "Fluffy", species: "kitty" } } }, 'change/pointer/point', function(){
gun.get('change/pointer/point').path('bob').any(function(err, data){
if(done.c){
expect(data.age).to.be(30);
expect(data.name).to.be('Bob!');
expect(Gun.val.link.is(data.pet)).to.be.ok();
expect(done.c).to.be(1);
done();
done.c = 2;
return;
}
expect(data.age).to.be(29);
expect(data.name).to.be('Bob!');
expect(Gun.val.link.is(data.pet)).to.be.ok();
done.c=1;
});
setTimeout(function(){
gun.get('change/pointer/point').path('bob').put({age: 30});
},400);
}, 1000);
});
it('mutate pointer to self deep', function(done){
Gun.statedisk({ bob: { age: 29, name: "Bob!", pet: { name: "Fluffy", species: "kitty" } } }, 'change/pointer/point/deep', function(){
gun.get('change/pointer/point/deep').path('bob').any(function(err, data){
//console.log("***", data);
if(done.c){
expect(data.age).to.be(30);
expect(data.name).to.be('Bob!');
expect(Gun.val.link.is(data.pet)).to.be.ok();
done();
return;
}
expect(data.age).to.be(29);
expect(data.name).to.be('Bob!');
expect(Gun.val.link.is(data.pet)).to.be.ok();
done.c=1;
});
setTimeout(function(){
gun.get('change/pointer/point/deep').path('bob').path('age').put(30);
},400);
}, 1000);
});
it('mutate pointer to primitive after any', function(done){
Gun.statedisk({ bob: {_: {'#': 'asdffdsa'}, age: 29, name: "Bob!", pet: { name: "Fluffy", species: "kitty" } } }, 'change/pointer/to/prime', function(){
var bob = gun.get('asdffdsa').any(function(err, data){
//console.log("***", data);
});
gun.get('change/pointer/to/prime').path('bob').any(function(err, data, f, at){
//console.log("***********", data);
if(!Gun.obj.is(data)){
expect(data).to.be(3);
if(done.c){return}
done();done.c=1;
return;
}
expect(data.age).to.be(29);
expect(data.name).to.be('Bob!');
expect(Gun.val.link.is(data.pet)).to.be.ok();
});
setTimeout(function(){
gun.get('change/pointer/to/prime').path('bob').put(3);
setTimeout(function(){
bob.put({age: 30});
},100);
},400);
}, 1000);
});
it('mutate pointer to primitive after any deep', function(done){
Gun.statedisk({ bob: { age: 29, name: "Bob!", pet: {_: {'#': 'sadffads'}, name: "Fluffy", species: "kitty" } } }, 'change/pointer/to/prime/deep', function(){
var cat = gun.get('sadffads').any(function(err, data){
//console.log("***", data);
});
gun.get('change/pointer/to/prime/deep').path('bob').path('pet').any(function(err, data){
//console.log("*********", data);
if(!Gun.obj.is(data)){
expect(data).to.be(undefined);
if(done.c){return}
done();done.c=1;
return;
}
expect(data.species).to.be('kitty');
expect(data.name).to.be('Fluffy');
});
setTimeout(function(){
gun.get('change/pointer/to/prime/deep').path('bob').put(3);
setTimeout(function(){
cat.put({laser_eyes: true});
},100);
},400);
}, 1000);
});
return;
it.only('mutate pointer to another pointer after any', function(done){
Gun.statedisk({ bob: {_: {'#': 'dafssfad'}, age: 29, name: "Bob!", pet: { name: "Fluffy", species: "kitty" } } }, 'change/pointer/to/pointer', function(){
var bob = gun.get('dafssfad').any(function(err, data){
console.log("***", data);
});
console.debug.i=1;console.log("--------------------");
gun.get('change/pointer/to/pointer').path('bob').any(function(err, data){
console.log("*********", data);return;
if(done.soul && done.soul !== Gun.node.soul(data)){
expect(Gun.node.soul(data)).to.be('fsdaadsf');
expect(data.cat).to.be(true);
expect(data.age).to.not.be.ok();
expect(data.name).to.not.be.ok();
expect(data.pet).to.not.be.ok();
if(done.c){return}
done();done.c=1;
return;
}
expect(done.soul = Gun.node.soul(data)).to.be('dafssfad');
expect(data.age).to.be(29);
expect(data.name).to.be('Bob!');
expect(Gun.val.link.is(data.pet)).to.be.ok();
});
return;
setTimeout(function(){
gun.get('change/pointer/to/pointer').path('bob').put(Gun.node.ify({cat: true}, 'fsdaadsf'));
setTimeout(function(){
bob.put({age: 30});
},100);
},400);
}, 1000);
});
return;
it.only('deep freeze put', function(done){
gun.get('deep/freeze').put({
bob: {
age: 29,
name: "Bob!",
pet: {
name: "Fluffy",
species: "kitty"
}
}
});
gun.get('deep/freeze').path('bob').path('pet').any(function(err, data){
console.log("********************", data);
expect(data.name).to.be('Fluffy');
expect(data.species).to.be('kitty');
setTimeout(function(){
done();
},100);
});
});
it('deep freezing put', function(done){
gun.get('deep/freeze/ing').put({
bob: {
age: 29,
name: "Bob!",
pet: {
name: "Fluffy",
species: "kitty"
}
}
});
gun.get('deep/freeze/ing').path('bob').path('pet').any(function(err, data){
//console.log("******** bob's pet", data);
if(done.c){
expect(data).to.be(undefined);
return;
}
expect(data.name).to.be('Fluffy');
expect(data.species).to.be('kitty');
done.c=1;
});
gun.get('deep/freeze/ing').put({bob: 'lol'});
gun.get('deep/freeze/ing').path('bob').path('pet').any(function(err, data){
//console.log("********* 2 bob's pet", data);return;
expect(data).to.be(undefined);
done();
});
});
return;
it('put put put put', function(){
var gun = Gun();
var get = gun.get('put/put/put/put');
get.put({});
get.put({
all: {
the: {
way: 'down'
}
}
});
get.put({foo: 'bar'});
get.any(function(err,data){
//console.log("data", data);
expect(Gun.val.link.is(data.all)).to.be.ok();
expect(data.foo).to.be('bar');
});
});
it('perf put', function(done){
var gun = Gun();
var hey = gun.get('heylo');
hey.put({hello: "world"});
hey.any(function(err, data){
expect(data.hello).to.be('world');
done();
});
});
it('put', function(done){
gun.put("hello", function(err, ok){
expect(err).to.be.ok();
done();
});
});
it('put NaN', function(done){
gun.put({num: NaN}, function(err, ok){
expect(err).to.be.ok();
done();
});
});
it('put date', function(done){
gun.put({date: new Date()}, function(err, ok){
expect(err).to.be.ok();
done();
});
});
it('put regex', function(done){
gun.put({reg: /regex/i}, function(err, ok){
expect(err).to.be.ok();
done();
});
});
it('put node', function(done){
gun.put({hello: "world"}, function(err, ok){
expect(err).to.not.be.ok();
done();
});
});
it('put node then value', function(done){
var ref = gun.put({hello: "world"});
//console.log("---------");
ref.put('hello', function(err, ok){
expect(err).to.be.ok();
done();
});
});
it('put node then put', function(done){
gun.put({hello: "world"}).put({goodbye: "world"}, function(err, ok){
expect(err).to.not.be.ok();
done();
});
});
it('put node with soul get soul', function(done){
gun.put({_: {'#': 'foo'}, hello: 'world'})
.get({'#': 'foo'}, function(err, node){
expect(err).to.not.be.ok();
expect(Gun.node.soul(node)).to.be('foo');
expect(node.hello).to.be('world');
if(done.c){ return }
done(); done.c = 1;
})
});
it('put node with soul get soul tweak', function(done){
Gun().put({_: {'#': 'foo'}, hello: 'world'});
setTimeout(function(){
var gun = Gun();
gun.put({_: {'#': 'foo'}, boo: 'bear'})
.get({'#': 'foo'}, function(err, node){
if(done.c >= 1){ return }
//console.log("**********", err, node);
expect(Gun.node.soul(node)).to.be('foo');
expect(err).to.not.be.ok();
expect(node.boo).to.be('bear');
//if(!done.c){ return done.c = 1 } done.c = 2;
//expect(node.hello).to.be('world');
done(); done.c = 2;
})
},100);
});
it('put node key get', function(done){
gun.put({hello: "key"}).key('yes/key', function(err, ok){
//console.log("***", err, ok);
expect(err).to.not.be.ok();
done.w = 1; if(done.c){ return } if(done.r){ done(); done.c = 1 };
}).get('yes/key', function(err, node){
//console.log("*******", err, node);
expect(err).to.not.be.ok();
expect(Gun.node.soul(node)).to.be('yes/key');
expect(node.hello).to.be('key');
done.r = 1; if(done.c){ return } if(done.w){ done(); done.c = 1 };
});
});
it('put node key gun get', function(done){
gun.put({hello: "a key"}).key('yes/a/key', function(err, ok){
expect(err).to.not.be.ok();
});
gun.get('yes/a/key', function(err, node){
expect(err).to.not.be.ok();
expect(node.hello).to.be('a key');
if(done.c){ return }
done(); done.c = 1;
});
});
it('gun key', function(){ // Revisit this behavior?
try{ gun.key('fail/key') }
catch(err){
expect(err).to.be.ok();
}
});
it('get key no override', function(done){
var gun = Gun();
gun.put({cream: 'pie'}).key('cream/pie').get('cream/pie', function(err, node){
expect(Gun.node.soul(node)).to.be('cream/pie');
if(done.c){ return }
if(node.cream && node.pie){
expect(node.cream).to.be('pie');
expect(node.pie).to.be('cream');
done(); done.c = 1;
} return;
if(done.c >= 2){ return }
if(done.c){ done(); done.c = 2; return; } done.c = 1;
});
gun.get('cream/pie').key('pie/cream');
gun.get('pie/cream').put({pie: 'cream'});
});
it('get key', function(done){
gun.get('yes/key', function(err, node){
expect(err).to.not.be.ok();
expect(node.hello).to.be('key');
}).key('hello/key', function(err, ok){
expect(err).to.not.be.ok();
done.key = true;
if(!done.c && done.yes){ done();done.c=1; }
}).key('yes/hello', function(err, ok){
expect(err).to.not.be.ok();
done.yes = true;
if(!done.c && done.key){ done();done.c=1; }
});
});
it('get key null', function(done){
gun.get('yes/key').key('', function(err, ok){
expect(err).to.be.ok();
done();
});
});
it('key node has no key relations', function(done){
var gun = Gun();
gun.put({hello: 'world'}).key('hello/earth');
gun.put({continent: 'africa'}).key('hello/earth');
gun.put({place: 'asia'}).key('hello/earth');
gun.put({north: 'america'}).key('hello/galaxy');
gun.put({south: 'pole'}).key('hello/galaxy');
gun.get('hello/earth').key('hello/galaxy', function(err, ok){
expect(err).to.not.be.ok();
});
var node = gun.back(-1)._.graph['hello/earth'] || {}; // TODO: IS THIS CORRECT?
expect(node['hello/galaxy']).to.not.be.ok();
gun.get('hello/earth', function(err, pseudo){
expect(pseudo.hello).to.be('world');
expect(pseudo.continent).to.be('africa');
expect(pseudo.place).to.be('asia');
expect(pseudo.north).to.not.be.ok();
});
var galaxy = gun.back(-1)._.graph['hello/galaxy'] || {}; // TODO: IS THIS CORRECT?
expect(galaxy['hello/earth']).to.not.be.ok();
gun.get('hello/galaxy', function(err, pseudo){
if(done.c || !pseudo.hello || !pseudo.south || !pseudo.place || !pseudo.continent || !pseudo.north){ return }
expect(pseudo.hello).to.be('world');
expect(pseudo.south).to.be('pole');
expect(pseudo.place).to.be('asia');
expect(pseudo.continent).to.be('africa');
expect(pseudo.north).to.be('america');
expect(pseudo['hello/earth']).to.not.be.ok();
expect(pseudo['#hello/earth#']).to.not.be.ok();
done(); done.c = 1;
});
});
function soulnode(gun, kn, r){ // TODO: WARNING! Key implementation has changed significantly. Tests are somewhat hardcoded, sad day.
r = r || [];
kn = Gun.obj.copy(kn);
delete kn._;
expect(Gun.obj.empty(kn, '##')).to.be.ok();
kn = gun.back(-1)._.graph[Gun.val.link.is(kn['##'])];
Gun.node.is(kn, function(node, s){
var n = gun.back(-1)._.graph[s];
if(Gun.obj.has(n, '##')){
soulnode(gun, n, r);
return;
}
r.push(s);
});
return r;
}
it('get node put node merge', function(done){
gun.get('hello/key', function(err, node){
if(done.soul){ return }
expect(err).to.not.be.ok();
expect(node.hello).to.be('key');
done.soul = Gun.node.soul(node);
}).put({hi: 'you'}, function(err, ok){
expect(err).to.not.be.ok();
var keynode = gun.back(-1)._.graph[done.soul], soul;
expect(keynode.hi).to.not.be.ok();
var c = soulnode(gun, keynode), soul = c[0];
expect(c.length).to.be(1);
var node = gun.back(-1)._.graph[soul];
expect(node.hello).to.be('key');
expect(node.hi).to.be('you');
}).on(function(node){
if(done.c){ return }
//expect(done.soul).to.be(Gun.node.soul(node)); // TODO: DISCUSSION! This has changed?
expect(node.hi).to.be('you');
expect(node.hello).to.be('key');
done(); done.c = 1;
});
});
it('get null put node never', function(done){ // TODO: GET returns nothing, and then doing a PUT?
gun.get(null, function(err, ok){
expect(err).to.be.ok();
done.err = true;
}).put({hi: 'you'}, function(err, ok){
done.flag = true;
});
setTimeout(function(){
expect(done.err).to.be.ok();
expect(done.flag).to.not.be.ok();
done();
}, 500);
});
it('get key no data put', function(done){
var gun = Gun({init: true});
gun.get('this/key/definitely/does/not/exist', function(err, data){
done.gcb = true;
done.err = err;
expect(err).to.not.be.ok();
expect(data).to.not.be.ok();
}).put({testing: 'stuff'}, function(err, ok){
done.flag = true;
});
setTimeout(function(){
expect(done.gcb).to.be.ok();
expect(done.err).to.not.be.ok();
expect(done.flag).to.not.be.ok();
done();
}, 500);
});
it('get node put node merge conflict', function(done){
gun.get('hello/key', function(err, node){
if(done.soul){ return }
expect(err).to.not.be.ok();
expect(node.hello).to.be('key');
expect(node.hi).to.be('you');
done.soul = Gun.node.soul(node);
}).put({hi: 'overwritten'}, function(err, ok){
if(done.c){ return }
expect(err).to.not.be.ok();
var keynode = gun.back(-1)._.graph[done.soul], soul;
var c = soulnode(gun, keynode), soul = c[0];
expect(c.length).to.be(1);
var node = gun.back(-1)._.graph[soul];
expect(node.hello).to.be('key');
expect(node.hi).to.be('overwritten');
done.w = 1; if(done.r){ done(); done.c = 1 };
}).on(function(node){
if(done.c){ return }
//expect(done.soul).to.be(Gun.node.soul(node)); // since put has changed chains, do we keep the pseudomerge key context?
expect(node.hello).to.be('key');
expect(node.hi).to.be('overwritten');
done.r = 1; if(done.w){ done(); done.c = 1 };
});
});
it('get key path put', function(done){
var gun = Gun().put({foo:'lol', extra: 'yes'}).key('key/path/put');
var data = gun.get('key/path/put');
data.path('foo').put('epic');
data.once(function(val, field){
expect(val.foo).to.be('epic');
expect(Gun.node.soul(val)).to.be('key/path/put');
done();
});
});
it('put node path', function(done){
var gun = Gun();
gun.put({hello: 'world'}).path('hello', function(err, val, field){
if(done.end){ return } // it is okay for path's callback to be called multiple times.
expect(err).to.not.be.ok();
expect(field).to.be('hello');
expect(val).to.be('world');
done(); done.end = true;
});
});
it('put node path path', function(done){
var gun = Gun();
//console.debug.i=1;console.log("-----------------");
var g = gun.put({hello: {little: 'world'}}).path('hello').path('little', function(err, val, field, cat){
if(done.end){ return } // it is okay for path's callback to be called multiple times.
expect(err).to.not.be.ok();
expect(field).to.be('little');
expect(val).to.be('world');
done(); done.end = true;
});
});
it('put node path rel', function(done){
gun.put({foo: {bar: 'lol'}}).path('foo', function(err, val, field){
//console.log("*****", err, val, field);
if(done.end){ return } // it is okay for path's callback to be called multiple times.
expect(err).to.not.be.ok();
expect(field).to.be('foo');
expect(val.bar).to.be('lol');
done(); done.end = true;
});
});
it('get node path', function(done){
gun.get('hello/key').path('hi', function(err, val, field){
if(done.end){ return } // it is okay for path's callback to be called multiple times.
expect(err).to.not.be.ok();
expect(field).to.be('hi');
expect(val).to.be('overwritten');
done(); done.end = true;
});
});
it('put node get field', function(done){ // future feature.
var gun = Gun();
gun.put({_:{'#': 'soul/field'}, hi: 'lol', foo: 'bar'});//.key('key/field');
gun.get({'#': 'soul/field', '.': 'hi'}, function(err, val){
//expect(val.hi).to.be('lol'); // TODO: REVISE API?
expect(val).to.be('lol');
//expect(Gun.obj.has(val,'foo')).to.not.be.ok();
done();
})
});
it('get node path put value', function(done){
gun.get('hello/key', function(err, node){
expect(err).to.not.be.ok();
if(done.soul){ return }
expect(node.hi).to.be('overwritten');
done.soul = Gun.node.soul(node);
}).path('hi').put('again', function(err, ok){
if(done.c){ return }
expect(err).to.not.be.ok();
var keynode = gun.back(-1)._.graph[done.soul], soul;
var c = soulnode(gun, keynode), soul = c[0];
expect(c.length).to.be(1);
var node = gun.back(-1)._.graph[done.sub = soul];
expect(node.hello).to.be('key');
expect(node.hi).to.be('again');
done.w = 1; if(done.r){ done(); done.c = 1 };
}).on(function(val, field){
if(done.c){ return }
expect(val).to.be('again');
expect(field).to.be('hi');
done.r = 1; if(done.w){ done(); done.c = 1 };
});
});
it('get node path put object', function(done){
var foo = gun.get('hello/key', function(err, node){
if(done.soul){ return }
expect(err).to.not.be.ok();
expect(node.hi).to.be('again');
expect(node.hello).to.be('key');
done.soul = Gun.node.soul(node);
}).path('hi').put({yay: "value"}, function(err, ok){
if(done.c){ return }
expect(err).to.not.be.ok();
var keynode = gun.back(-1)._.graph[done.soul], soul;
var c = soulnode(gun, keynode), soul = c[0];
expect(c.length).to.be(1);
var root = gun.back(-1)._.graph[soul];
expect(root.hello).to.be('key');
expect(root.yay).to.not.be.ok();
expect(Gun.val.link.is(root.hi)).to.be.ok();
expect(Gun.val.link.is(root.hi)).to.not.be(soul);
var node = gun.back(-1)._.graph[Gun.val.link.is(root.hi)];
expect(node.yay).to.be('value');
if(done.sub){ expect(done.sub).to.be(Gun.val.link.is(root.hi)) }
else { done.sub = Gun.val.link.is(root.hi) }
done.w = 1; if(done.r){ done(); done.c = 1 };
}).on(function(node, field){
if(done.c){ return }
expect(field).to.be('hi');
expect(node.yay).to.be('value');
if(done.sub){ expect(done.sub).to.be(Gun.node.soul(node)) }
else { done.sub = Gun.node.soul(node) }
done.r = 1; if(done.w){ done(); done.c = 1 };
});
});
it('get path wire', function(done){
var gun = Gun();
var get = gun.get('shallow/path');
var path = get.path('one');
var put = path.put('good');
put.once(function(val, field){
expect(val).to.be('good');
expect(field).to.be('one');
done();
});
});
it('get path wire shallow', function(done){
var gun = Gun();
var get = gun.get('slightly/shallow/path');
var path = get.path('one');
var put = path.put({you: 'are', here: 1});
put.once(function(val, field){
//console.log('***********', field, val);
expect(val.you).to.be('are');
expect(val.here).to.be(1);
expect(field).to.be('one');
done();
});
});
it('get put, Gun get path', function(done){ // For testing lazy eval that it works on cb style.
var gun = Gun();
gun.get('test').put({you: {are: 'cool'}});
// TODO: BUG!? Occasionally has a stack overflow???? :/
setTimeout(function(){
var g = Gun(); // TODO: NOTE! This will not work for in-memory only. This means it might not be viable as a test for core.
g.get('test').path('you', function(e,d){
if(!d || done.c){ return }
expect(d.are).to.be('cool');
done.c = true;
setTimeout(function(){
done();
},10);
});
},250);
});
it('get put, Gun get path to path', function(done){ // For testing lazy eval that it works on cb style.
var gun = Gun();
gun.get('test1').put({you: {are: 'cool'}});
setTimeout(function(){
var g = Gun(); // TODO: NOTE! This will not work for in-memory only. This means it might not be viable as a test for core.
var p = g.get('test1').path('you');
setTimeout(function(){
p.path('are', function(e,d){
if(!d || done.c){ return }
expect(d).to.be('cool');
done();done.c = true;
});
},100);
},100)
});
it('get put, Gun get path path', function(done){ // For testing lazy eval that it works on cb style.
var gun = Gun();
gun.get('test2').put({you: {are: 'cool'}});
setTimeout(function(){
var g = Gun(); // TODO: NOTE! This will not work for in-memory only. This means it might not be viable as a test for core.
var p = g.get('test2').path('you').path('are', function(e,d){
if(!d || done.c){ return }
expect(d).to.be('cool');
done();done.c=true;
});
},100);
});
it('get get not', function(done){
Gun.statedisk({ b: 1, c: 2 }, 'a', function(){
function cb(e,d,f,a){
if('b' === f && 1 === d){
done.b = true;
}
if('c' === f && 2 === d){
done.c = true;
}
if('d' === f && !d){
done.d = true;
}
if(done.done){ return }
if(done.b && done.c && done.d){
done.done = true;
done();
}
}
gun.get('a').path('b').get(cb);//.err(cb).not(cb).on(cb).once(cb);
gun.get('a').path('c').get(cb);//.err(cb).not(cb).on(cb).once(cb);
gun.get('a').path('d').get(cb);//.err(cb).not(cb).on(cb).once(cb);
}, 1000);
});
it('any not any not any not', function(done){
function cb(e,d,f,a){
if('b' === f && !d){
done.b = true;
}
if('c' === f && !d){
done.c = true;
}
if('d' === f && !d){
done.d = true;
}
if(done.b && done.c && done.d){
done();
}
}
gun.get('x').path('b').any(cb);//.err(cb).not(cb).on(cb).once(cb);
gun.get('x').path('c').any(cb);//.err(cb).not(cb).on(cb).once(cb);
gun.get('x').path('d').any(cb);//.err(cb).not(cb).on(cb).once(cb);
});
it('get put, put deep', function(done){
var gun = Gun();
var get = gun.get('put/deep/ish');
get.put({});
get.once(function(data){ // TODO: API CHANGE! Empty objects should react.
//console.log("...1", data);
expect(Gun.obj.empty(data, '_')).to.be.ok(); // API CHANGED,
//expect(Gun.val.link.is(data.very)).to.be.ok();
});//, {wait: 10000});
setTimeout(function(){
var put = get.put({
very: {
deep: {
ly: {
oriented: true
}
}
}
});
get.once(function(data){
//console.log("...2", data);
expect(Gun.val.link.is(data.very)).to.be.ok();
});
setTimeout(function(){
put.once(function(data){
//console.log("...3", data);
expect(Gun.val.link.is(data.very)).to.be.ok();
done.val = true;
});
var p = put.path('very');
p.put({we: 'have gone!'});
setTimeout(function(){
p.once(function(data){
//console.log("...4", data);
expect(data.we).to.be('have gone!');
expect(Gun.val.link.is(data.deep)).to.be.ok();
});
p.put('EXPLODE');
setTimeout(function(){
expect(done.val).to.be.ok();
done();
},5);
},150);
},250);
},110);
});
it('get path wire shallow swoop', function(done){
var gun = Gun();
var get = gun.get('slightly/shallow/path/swoop');
var path = get.path('one.two');
var put = path.put({oh: 'okay'});
put.once(function(val, field){
//console.log("****", field, val);
expect(val.oh).to.be('okay');
expect(field).to.be('two');
done();
});
});
it('get path wiring', function(done){
var gun = Gun();
var get = gun.get('deep/path');
var path = get.path('one.two');
var path3 = path.path('three');
var put = path3.put({you: 'found', the: 'bottom!'});
put.once(function(val, field){
//console.log("********1********", field, val);
expect(val.you).to.be('found');
expect(val.the).to.be('bottom!');
expect(field).to.be('three');
});
gun.get('deep/path').path('one.two.three.you').put('are').once(function(val, field){
//console.log("********2*********", field, val);return;
expect(val).to.be('are');
expect(field).to.be('you');
done();
});
});
it('get node path put object merge isolated', function(done){
// MORAL OF THE STORY: in KEY ON.GET check for change as NODE = AT.CHANGE || GUN.__.GRAPH[AT.soul] && Gun.node.soul(NODE, 'KEY') === 1; BAM!
var gun = Gun();
var put = gun.put({hello: 'key'}).key('hello/key/iso')
var get = gun.get('hello/key/iso');
var puthi = get.put({hi: 'you'});
puthi.on(function(node){
if(done.hi){ return }
//console.log(1, node);
expect(node.hello).to.be('key');
expect(node.hi).to.be('you');
done.hi = 1;
});
setTimeout(function(){
var get2 = gun.get('hello/key/iso');
var path2 = get2.path('hi');
path2._.id = 'path2';
var putyay = path2.put({yay: "value"});
putyay.on(function(node, field){
if(done.yay){ return }
expect(field).to.be('hi');
expect(node.yay).to.be('value');
done.yay = true;
});
setTimeout(function(){
var get3 = gun.get('hello/key/iso');
var path3 = get3.path('hi');
path3._.id = 'path3';
var puthappy = path3.put({happy: "faces"});
puthappy.on(function(node, field){
//console.log(3, field, node);
expect(field).to.be('hi');
expect(node.happy).to.be('faces');
expect(node.yay).to.be('value');
setTimeout(function(){
console.log("******************************");
done();
},200);
});
},100);
},100);
});
it('get node path put object merge', function(done){
var g = gun.get('hello/key', function(err, node){
if(done.soul){ return }
expect(err).to.not.be.ok();
expect(done.ref = Gun.val.link.is(node.hi)).to.be.ok();
done.soul = Gun.node.soul(node);
});
g.path('hi').put({happy: "faces"}, function(err, ok){
if(done.c){ return }
expect(err).to.not.be.ok();
var keynode = gun.back(-1)._.graph[done.soul], soul;
var c = soulnode(gun, keynode), soul = c[0];
expect(c.length).to.be(1);
var root = gun.back(-1)._.graph[soul];
var sub = gun.back(-1)._.graph[done.ref];
expect(root.hello).to.be('key');
expect(root.yay).to.not.be.ok();
expect(Gun.node.soul(sub)).to.be(done.ref);
expect(sub.yay).to.be('value');
expect(sub.happy).to.be('faces');
if(done.sub){ expect(done.sub).to.be(done.ref) }
else { done.sub = done.ref }
done.w = 1; if(done.r){ done(); done.c = 1 };
}).on(function(node, field){
if(done.c){ return }
expect(field).to.be('hi');
expect(node.happy).to.be('faces');
expect(node.yay).to.be('value');
if(done.sub){ expect(done.sub).to.be(Gun.node.soul(node)) }
else { done.sub = Gun.node.soul(node) }
done.r = 1; if(done.w){ done(); done.c = 1 };
});
});
it('get node path put value conflict relation', function(done){
gun.get('hello/key', function(err, node){
if(done.soul){ return }
expect(err).to.not.be.ok();
expect(done.ref = Gun.val.link.is(node.hi)).to.be.ok();
done.soul = Gun.node.soul(node);
}).path('hi').put('crushed', function(err, ok){
if(done.c){ return }
expect(err).to.not.be.ok();
var keynode = gun.back(-1)._.graph[done.soul], soul;
var c = soulnode(gun, keynode), soul = c[0];
expect(c.length).to.be(1);
var root = gun.back(-1)._.graph[soul];
var sub = gun.back(-1)._.graph[done.ref];
expect(root.hello).to.be('key');
expect(root.yay).to.not.be.ok();
expect(Gun.node.soul(sub)).to.be(done.ref);
expect(sub.yay).to.be('value');
expect(sub.happy).to.be('faces');
expect(root.hi).to.be('crushed');
done.w = 1; if(done.r){ done(); done.c = 1 };
}).on(function(val, field){
if(done.c){ return }
expect(field).to.be('hi');
expect(val).to.be('crushed');
done.r = 1; if(done.w){ done(); done.c = 1 };
});
});
it.skip('put gun node', function(done){
var mark = gun.put({age: 23, name: "Mark Nadal"});
var timber = gun.put({age: 3, name: "Timber Nadal"});
mark.path('boss').put(timber, function(err){
expect(err).to.not.be.ok();
});
mark.path('boss.name').once(function(val){
expect(val).to.be("timber Nadal");
});
});
it('put val', function(done){
gun.put({hello: "world"}).once(function(val){
expect(val.hello).to.be('world');
expect(done.c).to.not.be.ok();
done.c = 1;
});
setTimeout(function(){
expect(done.c).to.be.ok();
done();
}, 100);
});
it('put key val', function(done){
gun.put({hello: "world"}).key('hello/world').once(function(val, field){
if(done.c){ return }
expect(val.hello).to.be('world');
expect(done.c).to.not.be.ok();
done.c = 1;
});
setTimeout(function(){
expect(done.c).to.be.ok();
done();
}, 100);
});
it('get val', function(done){
gun.get('hello/world').once(function(val, field){
expect(val.hello).to.be('world');
expect(done.c).to.not.be.ok();
done.c = 1;
});
setTimeout(function(){
expect(done.c).to.be.ok();
done();
}, 100);
});
it('get path', function(done){
gun.get('hello/world').path('hello').once(function(val){
//console.log("**************", val);
expect(val).to.be('world');
expect(done.c).to.not.be.ok();
done.c = 1;
});
setTimeout(function(){
expect(done.c).to.be.ok();
done();
}, 1900);
});
it('get put path', function(done){
gun.get('hello/world').put({hello: 'Mark'}).path('hello').once(function(val, field){
expect(val).to.be('Mark');
expect(done.c).to.not.be.ok();
done.c = 1;
});
setTimeout(function(){
expect(done.c).to.be.ok();
done();
}, 100);
});
it('get path put', function(done){
gun.get('hello/world').path('hello').put('World').once(function(val){
expect(val).to.be('World');
expect(done.c).to.not.be.ok();
done.c = 1;
});
setTimeout(function(){
expect(done.c).to.be.ok();
done();
}, 100);
});
it('get empty put', function(done){
var gun = Gun({init: true});
gun.get('nothing/here').put({far: "wide"}, function(err, ok){
done.put = true;
});
gun.get({'#': 'asdfoobar'}).put({far: "wide"}, function(err, ok){
done.put2 = true;
});
setTimeout(function(){
expect(done.put).to.not.be.ok();
expect(done.put2).to.not.be.ok();
done();
}, 100)
});
it('get path empty put val', function(done){
var gun = Gun({init: true}).put({hello: "Mark"}).key('hello/world/not');
gun.get('hello/world/not').path('earth').put('mars').once(function(val){
done.c = 1;
});
setTimeout(function(){
expect(done.c).to.not.be.ok(); // CHANGELOG: API 0.3 BREAKING CHANGE, .put is suppose to be dependent on the previous chain, which means it SHOULD NOT PUT on an empty path.
done();
}, 100);
});
it('get empty put val implicit', function(done){
var gun = Gun();
var get = gun.get('hello/imp/world');
var put = get.put({planet: 'the earth'});
put.once(function(val){
expect(val.planet).to.be('the earth');
done();
});
});
it('get empty path put val implicit split', function(done){
var gun = Gun();
var get = gun.get('hello/imp/where');
var path = get.path('where');
var put = path.put('the mars');
var val = put.once(function(val, field){
expect(field).to.be('where');
expect(val).to.be('the mars');
done();
});
});
it('get path empty put val implicit', function(done){
gun.get('hello/world').path('earth').put('mars').once(function(val, field){
expect(val).to.be('mars');
expect(done.c).to.not.be.ok();
done.c = 1;
});
setTimeout(function(){
expect(done.c).to.be.ok();
done();
}, 100);
});
it('get path val', function(done){
var gun = Gun({init: true}).put({hello: "Mark"}).key('hello/world/not');
gun.get('hello/world').path('earth').put('mars');
gun.get('hello/world/not').path('earth').once(function(val){
expect(val).to.be('mars');
expect(done.c).to.not.be.ok();
done.c = 1;
});
setTimeout(function(){
expect(done.c).to.not.be.ok();
done();
}, 100);
});
it('get path val implicit', function(done){
gun.get('hello/world').path('earth').once(function(val){
expect(val).to.be('mars');
expect(done.c).to.not.be.ok();
done.c = 1;
});
setTimeout(function(){
expect(done.c).to.be.ok();
done();
}, 100);
});
describe('some nots', function(){
it('get not kick val', function(done){
gun.get("some/empty/thing").not(function(key, kick){ // that if you call not first
this.put({now: 'exists'}).key(key); // you can put stuff
}).once(function(val){ // and THEN still retrieve it.
expect(val.now).to.be('exists');
done();
});
});
it('get not kick val when it already exists', function(done){
var foo;
foo = gun.get("some/empty/thing");
foo.not(function(key, kick){
done.not = true;
this.put({now: 'THIS SHOULD NOT HAPPEN'}).key(key);
}).once(function(val){
expect(val.now).to.be('exists');
expect(done.not).to.not.be.ok();
done();
});
});
});
it('put path val sub', function(done){
gun.put({last: {some: 'object'}}).path('last').once(function(val){
expect(val.some).to.be('object');
done();
});
});
//return;
it('chain ordering', function(done){
var sec = gun.get('order/second');
var res = Gun.on.stun(sec);
gun.get('order/first', function(){ // this has a race condition against the third get. However if it fulfills first...
//console.log('callback', 0);
done.zero = true;
expect(done.one).to.not.be.ok();
expect(done.two).to.not.be.ok();
res(function(){
sec.any(function(){ // then this guy should be run before the third get, since it is queued first relative to this soul.
//console.log('callback', 1);
done.one = true;
expect(done.zero).to.be.ok();
expect(done.one).to.be.ok();
expect(done.two).to.not.be.ok();
res();
});
});
});
gun.get('order/second', function(){
//console.log('callback', 2);
done.two = true;
expect(done.zero).to.be.ok();
expect(done.one).to.be.ok();
expect(done.two).to.be.ok();
done();
});
});
it('get put null', function(done){
gun.put({last: {some: 'object'}}).path('last').once(function(val, field){
//console.log("**", field, val);
expect(field).to.be('last');
expect(val.some).to.be('object');
}).put(null).once(function(val, field){
//console.log("******", field, val);
expect(field).to.be('last');
expect(val).to.be(null);
done();
});
});
it('Gun get put null', function(done){ // flip flop bug
var gun = Gun();
gun.put({last: {some: 'object'}}).path('last').once(function(val, field){
//console.log("**", field, val);
done.some = true;
expect(val.some).to.be('object');
}).put(null).once(function(val, field){
//console.log("********", field, val);
expect(val).to.be(null);
expect(done.some).to.be.ok();
done();
});
});
it('var put key path', function(done){ // contexts should be able to be saved to a variable
var foo = gun.put({foo: 'bar'}).key('foo/bar');
foo.path('hello.world.nowhere'); // this should become a sub-context, that doesn't alter the original
setTimeout(function(){
foo.path('foo').once(function(val){ // and then the original should be able to be reused later
expect(val).to.be('bar'); // this should work
done();
});
}, 500);
});
it('var get path', function(done){ // contexts should be able to be saved to a variable
var foo = gun.get('foo/bar');
foo.path('hello.world.nowhere'); // this should become a sub-context, that doesn't alter the original
setTimeout(function(){
foo.path('foo').once(function(val){ // and then the original should be able to be reused later
expect(val).to.be('bar'); // this should work
done();
});
}, 500);
});
it('get not put val path val', function(done){
var todos = gun.get("examples/list/foobar").not(function(key){
this.put({
id: 'foobar',
title: 'awesome title',
todos: {}
}).key(key);
}).once(function(data){
expect(data.id).to.be('foobar');
//}).path('todos').once(function(todos, field){
}).path('todos').once(function(todos, field){
expect(field).to.be('todos');
expect(todos).to.not.have.property('id');
done();
}, {empty: true}); // API CHANGED! .val fires on empty by default now.
});
it('put circular ref', function(done){
var data = {};
data[0] = "DATA!";
data.a = {c: 'd', e: 1, f: true};
data.b = {x: 2, y: 'z'};
data.a.kid = data.b;
data.b.parent = data.a;
gun.put(data, function(err, ok){
expect(err).to.not.be.ok();
}).once(function(val){
setTimeout(function(){ // TODO: Is this cheating? I don't think so cause we are using things outside of the API!
var a = gun.back(-1)._.graph[Gun.val.link.is(val.a)];
var b = gun.back(-1)._.graph[Gun.val.link.is(val.b)];
expect(Gun.val.link.is(val.a)).to.be(Gun.node.soul(a));
expect(Gun.val.link.is(val.b)).to.be(Gun.node.soul(b));
expect(Gun.val.link.is(a.kid)).to.be(Gun.node.soul(b));
expect(Gun.val.link.is(b.parent)).to.be(Gun.node.soul(a));
done();
},10);
});
});
it('gun put path and some changes node', function(done){ done.c = 0;
var ref = gun.put({
foo: {bar: 'lol'}
});
var sub = ref.path('foo').on(function(val){
done.c++;
if(val){
expect(val.extra).to.not.be.ok();
}
if(done.c === 1){
expect(val.bar).to.be('lol');
ref.put({foo: 'hi'});
return;
}
if(done.c === 2){
expect(val).to.be('hi');
done();
}
});
});
it('gun put two nodes, link one, path and detach', function(done){ done.c = 0;
// this test is not written yet!
var ref = gun.put({
foo: {bar: 'lol'}
});
var sub = ref.path('foo').on(function(val){
done.c++;
if(val){
expect(val.extra).to.not.be.ok();
}
if(done.c === 1){
expect(val.bar).to.be('lol');
ref.put({foo: 'hi'});
return;
}
if(done.c === 2){
expect(val).to.be('hi');
done();
}
});
// ref.put({foo: {extra: 'field'}});
});
it('gun put path deep primitive', function(done){
gun.put({
foo: {
bar: {
lol: true
}
}
}).path('foo.bar.lol').once(function(val){
expect(val).to.be(true);
done();
});
});
it('gun put path deep node', function(done){
gun.put({
foo: {
bar: {
lol: {ok: true}
}
}
}).path('foo.bar.lol').once(function(val){
expect(val.ok).to.be(true);
done();
});
});
it('put circular deep', function(done){
var mark = {
age: 23,
name: "Mark Nadal"
}
var timber = {
age: 23,
name: "timber Nadal",
phd: true
}
mark.boss = timber;
timber.husband = mark;
var cat = {
age: 3,
name: "Hobbes"
}
mark.pet = cat;
timber.pet = cat;
cat.owner = mark;
cat.master = timber;
//console.debug.i=1;console.log("------------");
gun.put(mark, function(err, ok){
expect(err).to.not.be.ok();
}).once(function(val){
expect(val.age).to.be(23);
expect(val.name).to.be("Mark Nadal");
expect(Gun.val.link.is(val.boss)).to.be.ok();
expect(Gun.val.link.is(val.pet)).to.be.ok();
}).path('boss.pet.name').once(function(val){
//console.debug(1, "*****************", val);
expect(val).to.be('Hobbes');
}).back().path('pet.master').once(function(val){
//console.log("*****************", val);
expect(val.name).to.be("timber Nadal");
expect(val.phd).to.be.ok();
expect(val.age).to.be(23);
expect(Gun.val.link.is(val.pet)).to.be.ok();
done();
});
});
it('key get', function(done){
var gun = Gun();
gun.get('key/get').put({yay: 'something'}).key('index/yay');
gun.get('index/yay', function(err, node){
expect(node.yay).to.be('something');
if(done.c){return}
done();done.c=1;
});
});
it('put partial sub merge', function(done){
var gun = Gun();
var mark = gun.put({name: "Mark", boss: { name: "timber" }}).key('person/mark').once(function(mark){
//console.log("VAL1", mark);
done.marksoul = Gun.node.soul(mark);
expect(mark.name).to.be("Mark");
});
mark.put({age: 23, boss: {age: 3}});
setTimeout(function(){
mark.put({citizen: "USA", boss: {citizen: "USA"}}).once(function(mark){
//console.log("VAL2", mark, gun);
expect(mark.name).to.be("Mark");
expect(mark.age).to.be(23);
expect(mark.citizen).to.be("USA");
this.path('boss').on(function(timber){ // TODO: turn this .on back into a .val
//console.log("VAL3", timber);
if(done.c){ return }
expect(done.c).to.not.be.ok(); // RELATED TO BELOW #"CONTEXT NO DOUBLE EMIT".
expect(timber.name).to.be("timber");
expect(timber.age).to.be(23);
expect(timber.citizen).to.be("USA");
done();done.c=1;
});
});
}, 500);
});
it('path path', function(done){
var deep = gun.put({some: {deeply: {nested: 'value'}}});
deep.path('some.deeply.nested').once(function(val){
expect(val).to.be('value');
});
deep.path('some').path('deeply').path('nested').once(function(val){
expect(val).to.be('value');
done();
});
});
it('context null put value val error', function(done){
gun.put("oh yes", function(err){
expect(err).to.be.ok();
done();
});
});
it('context no double emit', function(done){ // annoying problem where somehow the gun.path in a put starts subscribing and firing to its context if we let get handle emitting for the chain in put.
var c = 0;
var gun = Gun();
var fo = gun.put({fo: 'bar'});
Gun.log.ba = 1;
fo.put({ba: {}}).once(function(obj, field){
c += 1;
expect(c).to.be(1);
done();
});
Gun.log.ba = 0;
var ba = fo.path('ba');
ba.put({co: 'do'});
});
describe('random', function(){
var foo;
it('context null put node', function(done){
foo = gun.put({foo: 'bar'}).once(function(obj){
expect(obj.foo).to.be('bar');
done(); //setTimeout(function(){ done() },1);
});
});
it('context node put val', function(done){
// EFFECTIVELY a TIMEOUT from the previous test. NO LONGER!
foo.put('banana', function(err){
expect(err).to.be.ok();
done(); //setTimeout(function(){ done() },1);
});
});
it('context node put node', function(done){
// EFFECTIVELY a TIMEOUT from the previous test. NO LONGER!
foo.put({bar: {zoo: 'who'}}).once(function(obj, field){
//console.log("terribly terrilby unpleasant", field, obj);
expect(obj.foo).to.be('bar');
expect(Gun.val.link.is(obj.bar)).to.ok();
done(); //setTimeout(function(){ done() },1);
});
});
var bar;
it('context node and field of relation put node', function(done){
// EFFECTIVELY a TIMEOUT from the previous test. NO LONGER!
bar = foo.path('bar');
expect(gleak.check()).to.not.be.ok();
bar.put({combo: 'double'}).once(function(obj, field){
//expect(obj.zoo).to.be('who');
expect(obj.combo).to.be('double');
done(); //setTimeout(function(){ done() },1);
});
});
it('context node and field put value', function(done){
// EFFECTIVELY a TIMEOUT from the previous test. NO LONGER!
var tar = foo.path('tar');
tar.put('zebra').once(function(val){
expect(val).to.be('zebra');
done(); //setTimeout(function(){ done() },1);
});
});
it('context node and field, put node', function(done){
// EFFECTIVELY a TIMEOUT from the previous test. NO LONGER!
bar.path('combo').put({another: 'node'}).once(function(obj){
expect(obj.another).to.be('node');
// double .vals here also RELATED to the #"context no double emit" but because of a faulty .not or .init system.
bar.once(function(node){
expect(Gun.val.link.is(node.combo)).to.be.ok();
expect(Gun.val.link.is(node.combo)).to.be(Gun.node.soul(obj));
done(); //setTimeout(function(){ done() },1);
});
});
});
});
it('val path put val', function(done){
var gun = Gun();
var al = gun.put({gender:'m', age:30, name:'alfred'}).key('user/alfred');
var beth = gun.put({gender:'f', age:22, name:'beth'}).key('user/beth');
al.once(function(a){
beth.put({friend: a}, function(err, ok){
expect(err).to.not.be.ok();
}).path('friend').once(function(aa){
expect(Gun.node.soul(a)).to.be(Gun.node.soul(aa));
done();
});
});
});
// TODO: Write a test that tests for keysoul has a key meta indicator.
// TODO: A soulsoul does not have a key meta indicator.
// TODO: Souls match their graph.
it('val path put val key', function(done){ // bug discovered from Jose's visualizer
var gun = Gun(), s = Gun.time.is(), n = function(){ return Gun.time.is() }
this.timeout(5000);
gun.put({gender:'m', age:30, name:'alfred'}).key('user/alfred');
gun.put({gender:'f', age:22, name:'beth' }).key('user/beth');
//gun.get('user/beth').path('friend').put(gun.get('user/alfred')); // ideal format which we have a future test for.
gun.get('user/alfred').once(function(a){
//console.log("*****", a);
//expect(a['_']['key']).to.be.ok();
gun.get('user/beth').put({friend: a}, function(err, ok){ // b - friend_of -> a
expect(err).to.not.be.ok();
var keynode = gun.back(-1)._.graph['user/alfred'];
var c = soulnode(gun, keynode), soul = c[0];
expect(c.length).to.be(1);
});
gun.get('user/beth').once(function(b){
//console.log("beth", b);
gun.get('user/alfred').put({friend: b}).once(function(al){ // a - friend_of -> b
//console.log("al again", al);
gun.get('user/beth').put({cat: {name: "fluffy", age: 3, coat: "tabby"}}).once(function(bet){
gun.get('user/alfred').path('friend.cat').key('the/cat');
gun.get('the/cat').once(function(c){
//console.log("cat!!!", c);
expect(c.name).to.be('fluffy');
expect(c.age).to.be(3);
expect(c.coat).to.be('tabby');
done();
});
});
});
});
});
});
it('map', function(done){
var c = 0, set = gun.put({a: {here: 'you'}, b: {go: 'dear'}, c: {sir: '!'} });
set.map(function(obj, field){
c++;
if(field === 'a'){
expect(obj.here).to.be('you');
}
if(field === 'b'){
expect(obj.go).to.be('dear');
}
if(field === 'c'){
expect(obj.sir).to.be('!');
}
if(c === 3){
done();
}
})
});
it.skip('key soul', function(done){ // TODO: Deprecated? Maybe.
var gun = Gun();
gun.key('me', function(err, ok){
expect(err).to.not.be.ok();
var keynode = gun.back(-1)._.graph['me'];
var c = soulnode(gun, keynode), soul = c[0];
expect(c.length).to.be(1);
expect(soul).to.be('qwertyasdfzxcv');
done();
}, 'qwertyasdfzxcv');
});
it.skip('no false positive null emit', function(done){ // TODO: THE API HAS CHANGED! REDO TEHSE!
var gun = Gun({wire: {get: function(key, cb){
var g = {};
g[soul] = {_: {'#': soul, '>': {'a': 0}},
'a': 'b'
};
cb(null, g);
g = {};
g[soul] = {_: {'#': soul, '>': {'c': 0}},
'c': 'd'
};
cb(null, g);
g = {};
g[soul] = {_: {'#': soul }};
cb(null, g);
cb(); // false trigger!
}}}), soul = Gun.text.random();
gun.get(soul).not(function(err, ok){
done.fail = true;
}).once(function(val){
setTimeout(function(){
expect(val.a).to.be('b');
expect(val.c).to.be('d');
expect(done.fail).to.not.be.ok();
done();
},5);
});
});
it.skip('unique val on stream', function(done){ // TODO: THE API HAS CHANGED! REDO TEHSE!
var gun = Gun({wire: {get: function(key, cb){
if(Gun.obj.has(key, '#')){
key = key['#'];
var node = tmp.graph[key];
cb(null, node);
cb(null, Gun.is.node.ify({}, key));
cb(null, {});
}
}}}), tmp = {graph: {}};
tmp.graph[tmp.soul = Gun.text.random()] = tmp.node = {a: 'b', c: 'd'};
Gun.is.node.ify(tmp.node, tmp.soul);
tmp.graph['me'] = tmp.keynode = {};
Gun.obj.put(tmp.rel = {}, '#', tmp.soul);
tmp.keynode[tmp.soul] = tmp.rel;
Gun.is.node.ify(tmp.keynode, 'me');
tmp.keynode['#']['key'] = 1;
gun.get('me', function(err, data){
}).once(function(val){
done.count = (done.count || 0) + 1;
setTimeout(function(){
expect(val.a).to.be('b');
expect(val.c).to.be('d');
expect(done.count).to.be(1);
done();
},5);
});
});
it.skip('unique path val on stream', function(done){ // TODO: THE API HAS CHANGED! REDO TEHSE!
var gun = Gun({wire: {get: function(key, cb){
var n = {};
n = {_: {'#': soul, '>': {'a': 0}},
'a': 'a'
};
cb(null, n);
n = {};
n = {_: {'#': soul, '>': {'a': 1}},
'a': 'b'
};
cb(null, n);
n = {};
n = {_: {'#': soul }};
cb(null, n);
}}}), soul = Gun.text.random();
gun.get(soul).path('a').once(function(val){
done.count = (done.count || 0) + 1;
setTimeout(function(){
expect(val).to.be('b');
expect(done.count).to.be(1);
done();
},5);
});
});
it('double not', function(done){ // from the thought tutorial
var gun = Gun(gopt).get('thoughts').not(function(key){
this.put({}).key(key);
});
setTimeout(function(){
gun.not(function(){
done.not = true;
}).once(function(){
expect(done.not).to.not.be.ok();
done();
}, {empty: true});
}, 10);
});
it('node path node path node path', function(done){
var gun = Gun(/*gopt*/);
var data = gun.get('data');
gun.put({
a: 1,
b: 2,
c: 3
}).key('data');
data.path('a', function(e, v, f){
//console.log("FIRST", e,v,f);
expect(done.D).to.not.be.ok();
if(done.a){return}
expect(done.a).to.not.be.ok();
expect(v).to.be(1);
done.a = true;
});
data.path('b', function(e, v, f){
//console.log("SECOND", e,v,f);
expect(done.D).to.not.be.ok();
if(done.b){return}
expect(done.b).to.not.be.ok();
expect(v).to.be(2);
done.b = true;
});
data.path('c', function(e, v, f){
//console.log("THIRD", e,v,f);
expect(done.D).to.not.be.ok();
if(done.c){return}
expect(done.c).to.not.be.ok();
expect(v).to.be(3);
done.c = true;
});
setTimeout(function(){//return;
done.D=true;
data.put({d: 4});
expect(done.a).to.be.ok();
expect(done.b).to.be.ok();
expect(done.c).to.be.ok();
done();
},250);
});
it('node path obj node path obj node path obj', function(done){
var gun = Gun();
var data = gun.get('data1');
gun.put({
a: {v: 1},
b: {v: 2},
c: {v: 3}
}).key('data1');
data.path('a', function(e, v, f){
//console.log("FIRST", f,v);
expect(done.D).to.not.be.ok();
if(done.a){return}
expect(done.a).to.not.be.ok();
expect(v.v).to.be(1);
done.a = true;
});
data.path('b', function(e, v, f){
//console.log("SECOND", f,v);
expect(done.D).to.not.be.ok();
if(done.b){return}
expect(done.b).to.not.be.ok();
expect(v.v).to.be(2);
done.b = true;
});
data.path('c', function(e, v, f){
//console.log("THIRD", f,v);
expect(done.D).to.not.be.ok();
if(done.c){return}
expect(done.c).to.not.be.ok();
expect(v.v).to.be(3);
done.c = true;
});
setTimeout(function(){
done.D = true;
//data.put({d: {v: 4}});
expect(done.a).to.be.ok();
expect(done.b).to.be.ok();
expect(done.c).to.be.ok();
done();
},100);
});
describe('prototype crash', function(){
it('instance.key', function(done){
Gun().key('oye', function(err){
expect(err).to.be.ok();
done();
});
});
it('instance.on', function(done){
Gun().on();
done();
});
it('instance.path', function(done){
Gun().path('oye', function(err){
expect(err).to.be.ok();
done();
});
});
it('instance.map', function(done){
Gun().map();
done();
});
it('instance.not', function(done){
Gun().not();
done();
});
it('instance.val', function(done){
Gun().once();
done();
});
});
it('implicit put on empty get', function(done){
var gun = Gun().get('init');
gun.on(function(val){
expect(val.not).to.be(true);
if(done.c){ return } done(); done.c = 1;
});
gun.put({not: true});
});
it.skip('implicit put on empty get explicit not', function(done){ // HUH? This seems like wrong behavior.
var gun = Gun().get('init/not').not();
gun.on(function(val){
console.log("??", val);
done.c = 1;
});
gun.put({not: true});
setTimeout(function(){
expect(done.c).to.not.be.ok();
done();
},1);
});
it('no implicit put on empty get', function(done){
var gun = Gun({init: true}).get('not/init');
gun.on(function(val){
console.log("hmmm???", val);
expect(val.not).to.be(true);
if(done.c){ return } done.c = 1;
});
gun.put({not: true});
setTimeout(function(){
expect(done.c).to.not.be.ok();
done();
},1);
});
it('no implicit put on empty get explicit init', function(done){
var gun = Gun({init: true}).get('not/init/init').init();
gun.on(function(val){
if(val.not){
expect(val.not).to.be(true);
if(done.c){return}
done();done.c=1;
return;
}
expect(Gun.obj.empty(val, '_')).to.be.ok();
});
gun.put({not: true})
});
it('init', function(done){
var gun = Gun().get('init/todo').init();
gun.on(function(val){
console.log("*******", val);
if(done.c){return}
if(val.data){
expect(val.data).to.be('initialized!');
done();done.c=1;
return;
}
expect(Gun.obj.empty(val, '_')).to.be.ok();
});
gun.put({data: 'initialized!'});
});
describe('map able', function(){
it('map chain', function(done){
Gun().put({a:1, b:2}).map().on(function(v,f){
done[f] = v;
if(done.a && done.b){
done();
}
});
});
it('map chain after', function(done){
var g = Gun().get('m/c/a');
g.map().on(function(v,f){
done[f] = v;
if(done.a && done.b){
done();
}
});
g.put({a:1, b:2});
});
it('map chain map to', function(done){
var g = Gun().get('m/c/m/to');
var obj = {
a: {x: 1, y: 2, z: 3},
b: {u: 4, v: 5, w: 6}
}, check = {x:1,y:1,z:1,u:1,v:1,w:1};
g.map().map().on(function(v,f){
check[f] = 0;
if(Gun.obj.map(check, function(v,f){if(v){return true}})){return}
done();
});
setTimeout(function(){
g.put(obj);
},110);
});
it('map chain map', function(done){
var g = Gun().get('m/c/m');
var obj = {
a: {x: 1, y: 2, z: 3},
b: {u: 4, v: 5, w: 6}
}, check = {x:1,y:1,z:1,u:1,v:1,w:1};
g.map().map().on(function(v,f){
check[f] = 0;
if(Gun.obj.map(check, function(v,f){if(v){return true}})){return}
done();
});
g.put(obj);
});
it('map chain map before', function(done){
var g = Gun().get('m/c/m/b');
var obj = {
a: {x: 1, y: 2, z: 3},
b: {u: 4, v: 5, w: 6}
}, check = {x:1,y:1,z:1,u:1,v:1,w:1};
g.put(obj);
g.map().map().on(function(v,f){
check[f] = 0;
if(Gun.obj.map(check, function(v,f){if(v){return true}})){return}
done();
});
});
});
it('init todo', function(done){
var gun = Gun(), todo = gun.get('init/todo/early');
todo.path('random1').put('eat chocolate');
todo.map().on(function(val, field){
expect(val).to.be('eat chocolate');
expect(field).to.be('random1');
if(done.c){ return } done(); done.c = 1;
});
});
it('init todo defer', function(done){
var gun = Gun(), todo = gun.get('init/todo/defer');
todo.map().on(function(val, field){
expect(val).to.be('eat chocolate');
expect(field).to.be('random1');
if(done.c){ return } done(); done.c = 1;
});
setTimeout(function(){
todo.path('random1').put('eat chocolate');
}, 100);
});
/* // CHANGELOG: API 0.3 BREAKING CHANGE, .set has been deprecated!
it('set', function(done){
done.c = 0;
var u, gun = Gun();
gun.get('set').set().set().once(function(val){
var keynode = gun.__.graph['set'];
expect(Gun.node.soul.ify(keynode, '.')).to.be.ok();
Gun.is.node(keynode, function(rel, soul){
rel = gun.__.by(soul).node;
expect(Gun.obj.empty(rel, Gun._.meta)).to.be.ok();
});
done.c += 1;
setTimeout(function(){
expect(done.c).to.be(1);
done()
},10);
});
});
it('root set', function(done){
var gun = Gun().set();
gun.on(function(val, field){
expect(Gun.obj.empty(val, Gun._.meta)).to.be.ok();
if(done.c){return} done(); done.c = 1;
});
});
// TODO: BUG! We need 2 more tests... without .set()... and multiple paths on the same node.
it('set multiple', function(done){ // kinda related to flip flop?
var gun = Gun().get('sets').set(), i = 0;
gun.once(function(val){
console.log("TEST 1", val);
expect(Gun.obj.empty(val, Gun._.meta)).to.be.ok();
expect(Gun.node.soul(val)).to.be('sets');
var keynode = gun.__.graph['sets'];
expect(Gun.obj.empty(keynode, Gun._.meta)).to.not.be.ok();
});
gun.set(1); //.set(2).set(3).set(4); // if you set an object you'd have to do a `.back`
gun.map(function(val, field){
//gun.map().once(function(val, field){ // TODO: SEAN! DON'T LET ME FORGET!
console.log("\n TEST 2+", field, val);
return;
i += 1;
expect(val).to.be(i);
if(i % 4 === 0){
setTimeout(function(){
done.i = 0;
Gun.obj.map(gun.__.graph, function(){ done.i++ });
expect(done.i).to.be(1); // make sure there isn't double.
Gun.log.verbose = false;
done()
},10);
}
});
gun.set(2);
});
*/
it('val should not print relation', function(done){ // #132
var users = Gun().get('example').path('users');
users.path(Gun.text.random()).put('bob');
users.path(Gun.text.random()).put('sam');
setTimeout(function(){
users.once(function(v){
expect(Gun.val.link.is(v)).to.not.be.ok();
expect(Object.keys(v).length).to.be(3);
done();
});
},100);
});
it('peer 1 get key, peer 2 put key, peer 1 val', function(done){
var hooks = {get: function(key, cb, opt){
cb();
}, put: function(nodes, cb, opt){
Gun.union(gun1, nodes);
cb();
}},
gun1 = Gun({wire: {get: hooks.get}}).get('race')
, gun2 = Gun({wire: hooks}); //.get('race');
setTimeout(function(){
gun2.put({the: 'data'}).key('race');
setTimeout(function(){
gun1.on(function(val){
expect(val.the).to.be('data');
if(done.c){ return } done(); done.c = 1;
});
},10);
},10);
});
it('get pseudo merge', function(done){
var gun = Gun();
gun.put({a: 1, z: -1}).key('pseudo');
gun.put({b: 2, z: 0}).key('pseudo');
gun.get('pseudo').once(function(val){
expect(val.a).to.be(1);
expect(val.b).to.be(2);
expect(val.z).to.be(0);
done();
});
});
it('get pseudo merge on', function(done){
var gun = Gun();
gun.put({a: 1, z: -1}).key('pseudon');
gun.put({b: 2, z: 0}).key('pseudon');
gun.get('pseudon').on(function(val){
if(done.val){ return } // TODO: Maybe prevent repeat ons where there is no diff? (may not happen to after 1.0.0)
done.val = val;
expect(val.a).to.be(1);
expect(val.b).to.be(2);
expect(val.z).to.be(0);
done();
});
});
it.skip('get pseudo merge across peers', function(done){ // TODO: These tests should be replaced with PANIC tests!
// ctx.halt
var acb, bcb, ag, bg;
Gun.on('opt').event(function(gun, o){
if(connect){ return }
gun.__.opt.wire = {get: function(key, cb, opt){
key = key['#'];
if(o.alice){ acb = cb; ag = gun.__.graph; } else { bcb = cb; bg = gun.__.graph; }
var other = (o.alice? gun2 : gun1);
if(connect){
var node = other.__.graph[key];
cb(null, node);
} else {
cb();
}
}, put: function(nodes, cb, opt){
var other = (o.alice? gun2 : gun1);
if(connect){
Gun.union(other, nodes);
}
cb();
}}
});
function pushAtoB(key){
var node = ag[key];
bcb(null, node);
}
function pushBtoA(key){
var node = bg[key];
acb(null, node);
}
var connect, gun1 = Gun({alice: true}).get('pseudo/merge').put({hello: 'world!'})/*.not(function(key){
this.put({hello: "world!"}).key(key);
})*/, gun2;
gun1.once(function(val){
expect(val.hello).to.be('world!');
});
setTimeout(function(){
gun2 = Gun({bob: true}).get('pseudo/merge').put({hi: 'mars!'})/*.not(function(key){
this.put({hi: "mars!"}).key(key);
});*/
gun2.once(function(val){
expect(val.hi).to.be('mars!');
});
setTimeout(function(){
// CONNECT THE TWO PEERS
connect = true;
pushBtoA('pseudo/merge');
pushAtoB('pseudo/merge');
//gun1.get('pseudo/merge', null, {force: true}); // fake a browser refersh, in real world we should auto-reconnect
//gun2.get('pseudo/merge', null, {force: true}); // fake a browser refersh, in real world we should auto-reconnect
setTimeout(function(){
gun1.once(function(val){
expect(val.hello).to.be('world!');
expect(val.hi).to.be('mars!');
done.g1 = true;
});
//return;
gun2.once(function(val){
expect(val.hello).to.be('world!');
expect(val.hi).to.be('mars!');
expect(done.g1).to.be.ok();
Gun({});
done();
});
},10);
},10);
},10);
});
it("get map val -> map val", function(done){ // Terje's bug
var gun = Gun(); // we can test GUN locally.
var passengers = gun.get('passengers').not(function(key){
this.put({'randombob': {
name: "Bob",
location: {'lat': '37.6159', 'lng': '-128.5'},
direction: '128.2'
}, 'randomfred': {
name: "Fred",
location: {'lat': 'f37.6159', 'lng': 'f-128.5'},
direction: 'f128.2'
}}).key(key);
}); // this is now a list of passengers that we will map over.
var ctx = {n: 0, d: 0, l: 0};
passengers.map().once(function(passenger, id){
this.map().once(function(change, field){
if('name' == field){ expect(change).to.be(passenger.name); ctx.n++ }
if('direction' == field){ expect(change).to.be(passenger.direction); ctx.d++ }
if('location' == field){
delete change._; ctx.l++;
if('Bob' == passenger.name){
expect(change).to.eql({'lat': '37.6159', 'lng': '-128.5'});
} else {
expect(change).to.eql({'lat': 'f37.6159', 'lng': 'f-128.5'});
}
}
if(ctx.n == 2 && ctx.d == 2 && ctx.l == 2){ done() }
});
});
});
it("put map update sub", function(done){
var g = Gun();
var list = gun.get('map/sub');
list.put({a: {x:1}, b: {y: 1}});
var check = {};
list.map().on(function(v,f){
check[f] = v;
if(done.c){return}
if(check.a && check.b && check.a.w){
expect(check.a.x).to.be(1);
expect(check.b.y).to.be(1);
expect(check.a.w).to.be(2);
done.c=1;
done();
}
});
list.path('a').path('w').put(2);
});
it("put map update sub val", function(done){
var g = Gun();
var list = gun.get('map/sub/val');
list.put({a: {x:1}, b: {y: 1}});
list.path('a').path('w').put(2);
var check = {};
list.map().once(function(v,f){
check[f] = v;
console.log("*************************", f,v);
if(check.a && check.b){
expect(check.a.w).to.be(2);
expect(check.a.x).to.be(1);
expect(check.b.y).to.be(1);
done();
}
}, {wait: 400});
});
it("put map update sub val after", function(done){
var g = Gun();
var list = gun.get('map/sub/val/after');
var check = {};
list.map().once(function(v,f){
check[f] = v;
if(check.a && check.b){
setTimeout(function(){
expect(check.a.x).to.be(1);
expect(check.b.y).to.be(1);
expect(check.a.w).to.not.be.ok();
expect(done.c).to.not.be.ok();
done();done.c=1;
},400);
}
});
list.put({a: {x:1}, b: {y: 1}});
setTimeout(function(){
list.path('a').path('w').put(2);
},300);
});
it("put map update sub val after to", function(done){
var g = Gun();
var list = gun.get('map/sub/val/after/to');
var check = {};
list.map().once(function(v,f){
//console.log("*************", f,v);return;
check[f] = v;
if(check.a && check.b){
setTimeout(function(){
expect(check.a.x).to.be(1);
expect(check.b.y).to.be(1);
expect(check.a.w).to.be(2);
expect(done.c).to.not.be.ok();
done();done.c=1;
},200);
}
});
list.put({a: {x:1}, b: {y: 1}});
list.path('a').path('w').put(2);
});
it("put map simple after", function(done){
var g = Gun();
var list = gun.get('map/simple/after');
var check = {};
list.map().once(function(v,f){
check[f] = v;
if(check.a && check.b){
setTimeout(function(){
expect(check.a).to.be(2);
expect(check.b).to.be(1);
expect(done.c).to.not.be.ok();
done();done.c=1;
},200);
}
});
list.put({a: 1, b: 1});
list.path('a').put(2);
});
it("put map simple after to", function(done){
var g = Gun();
var list = gun.get('map/simple/after/to');
var check = {};
list.map().once(function(v,f){
check[f] = v;
if(check.a && check.b){
setTimeout(function(){
expect(check.a).to.be(1);
expect(check.b).to.be(1);
expect(done.c).to.not.be.ok();
done();done.c=1;
},200);
}
});
list.put({a: 1, b: 1});
setTimeout(function(){
list.path('a').put(2);
},300);
});
it("put map", function(done){
var gun = Gun();
var get = gun.get('map/that');
var put = gun.put({a: 1, b: 2, c: 3}).key('map/that');
get.map(function(v,f){
if(1 === v){ done.a = true }
if(2 === v){ done.b = true }
if(3 === v){ done.c = true }
if(done.a && done.b && done.c){
if(done.done){ return }
done(); done.done = 1;
}
});
});
it("put map before", function(done){
var gun = Gun();
var get = gun.get('map/that/before');
get.map(function(v,f){
if(1 === v){ done.a = true }
if(2 === v){ done.b = true }
if(3 === v){ done.c = true }
if(done.a && done.b && done.c){
if(done.done){ return }
done(); done.done = 1;
}
});
var put = get.put({a: 1, b: 2, c: 3});
});
it("get map map val", function(done){ // Terje's bug
var gun = Gun(/*{init: true}*/); // we can test GUN locally.
var passengers = gun.get('passengers/map').not(function(key){
gun.put({randombob: {
name: "Bob",
location: {'lat': '37.6159', 'lng': '-128.5'},
direction: '128.2'
}}).key(key);
}); // this is now a list of passengers that we will map over.
var ctx = {n: 0, d: 0, l: 0};
passengers.map().map().once(function(val, field){
if('name' == field){ expect(val).to.be(!ctx.n? 'Bob' : 'Fred'); ctx.n++ }
if('direction' == field){ expect(val).to.be(!ctx.d? '128.2' : 'f128.2'); ctx.d++ }
if('location' == field){
delete val._;
if(!ctx.l){
expect(val).to.eql({'lat': '37.6159', 'lng': '-128.5'});
} else {
expect(val).to.eql({'lat': 'f37.6159', 'lng': 'f-128.5'});
}
ctx.l++;
}
if(ctx.n == 2 && ctx.d == 2 && ctx.l == 2){ done() }
});
setTimeout(function(){
passengers.put({randomfred: {
name: "Fred",
location: {'lat': 'f37.6159', 'lng': 'f-128.5'},
direction: 'f128.2'
}});
},400);
});
it("not before map deep after conflict", function(done){
var gun = Gun();
var g = gun.get('n/b/l/a/c').not(function(k){
console.log("not", k);
gun.put({
a: {
x:1,
y:1
}
}).key('n/b/l/a/c');
});
var check = {a:{},b:{}}, F = 'a';
g.map().map().once(function(v,f){
var c = check[F];
c[f] = v;
if(check.b && check.b.x && check.b.y){
expect(check.a.x).to.be(1);
expect(check.a.y).to.be(1);
expect(check.b.x).to.be(1);
expect(check.b.y).to.be(1);
done();
}
});
setTimeout(function(){
F = 'b';
g.put({b: {x:1,y:1}});
},400);
});
it("not before map deep after", function(done){
var gun = Gun();
var g = gun.get('n/b/l/a').not(function(k){
console.log("not", k);
gun.put({
a: {
x:1,
y:1
}
}).key('n/b/l/a');
});
var check = {};
g.map().map().once(function(v,f){
check[f] = v;
if(check.x && check.y && check.w && check.u){
expect(check.x).to.be(1);
expect(check.y).to.be(1);
expect(check.w).to.be(1);
expect(check.u.deep).to.be(true);
done();
}
});
setTimeout(function(){
g.put({b: {w:1,u:{deep:true}}});
},400);
});
it("before map after", function(done){
var gun = Gun();
var g = gun.get('b/l/a');
g.put({a: {x:1,y:1}});
var check = {};
g.map().map().once(function(v,f){
check[f] = v;
if(check.x && check.y && check.w && check.u && check.z){
expect(check.x).to.be(1);
expect(check.w).to.be(1);
expect(check.u).to.be(1);
expect(check.y).to.be(2);
expect(check.z).to.be(1);
done();
}
});
setTimeout(function(){
g.put({b: {w:1,u:1,y:2,z:1}});
},150);
});
it("before map deep after", function(done){
var gun = Gun();
var g = gun.get('b/d/l/a');
g.put({a: {x:1,y:1}});
var check = {};
g.map().map().once(function(v,f){
check[f] = v;
if(check.x && check.y && check.w && check.u){
expect(check.x).to.be(1);
expect(check.y).to.be(1);
expect(check.w).to.be(1);
expect(check.u.deep).to.be(true);
done();
}
});
setTimeout(function(){
g.put({b: {w:1,u:{deep:true}}});
},150);
});
it("get map map map map", function(done){
var gun = Gun();
var g = gun.get('m/m/m/m');
console.log(" // TODO: BUG!!! If you make them have the same fields, they do not both iterate.");
g.put({
a: {
b: {
c: {
d: 1,
e: 2,
f: 3
}
}
},
u: {
v: {
w: {
d: 1,
e: 2,
f: 3
}
}
}
});
var check = {};
g.map().map().map().map().once(function(v,f){
check[f] = (check[f] || 0) + 1;
if(check.d === 2 && check.e === 2 && check.f === 2){
done();
}
});
});
it("get users map path path any", function(done){
var gun = Gun();
var check = {};
gun.get('g/n/m/f').map().path('spouse').path('work').any(function(e,v,f){
console.log("********", f,v, this);
check[v.name] = true;
if(check["ACME INC"] && check["GUN INC"]){
done();
}
});
gun.put({_:{'#':'g/n/m/f'},
alice: {
name: "alice",
age: 24,
spouse: {
name: "carl",
age: 25,
work: {
name: "GUN INC"
}
},
bout: {huh:1}
},
bob: {
name: "bob",
age: 26,
spouse: {
name: "diana",
age: 27,
work: {
name: "ACME INC"
}
}
},
});
});
it("get users map path path val after", function(done){
var gun = Gun();
gun.put({_:{'#':'g/n/m/f/a'},
alice: {
name: "alice",
age: 24,
spouse: {
name: "carl",
age: 25,
work: {
name: "GUN INC"
}
},
bout: {huh:1}
},
bob: {
name: "bob",
age: 26,
spouse: {
name: "diana",
age: 27,
work: {
name: "ACME INC"
}
}
},
});
setTimeout(function(){
//console.debug.i=1;console.log("----------------------");
var check = {};
gun.get('g/n/m/f/a').map().path('spouse').path('work').any(function(e,v,f){
console.log("********", f,v, this);
check[v.name] = true;
if(check["ACME INC"] && check["GUN INC"]){
done();
}
});
},100);
});
it("get users map path path any later", function(done){
var gun = Gun();
gun.get('g/n/m/f/l').map().path('spouse').path('work');
gun.put({_:{'#':'g/n/m/f/l'},
alice: {
name: "alice",
age: 24,
spouse: {
name: "carl",
age: 25,
work: {
name: "GUN INC"
}
},
bout: {huh:1}
},
bob: {
name: "bob",
age: 26,
spouse: {
name: "diana",
age: 27,
work: {
name: "ACME INC"
}
}
},
});
setTimeout(function(){
var work = {};
console.log("..........", gun);
return;
gun.get('g/n/m/f').map().path('spouse').path('work').any(function(e,v,f){
console.log("********", f,v, this);
return;
check[v.name] = true;
if(check["ACME INC"] && check["GUN INC"]){
done();
}
});
},100);
});
it("get graph node field ref", function(done){
var gun = Gun();
gun.put({data: {a: 1, b: 2}}, null, 'g/n/f')
console.debug.i=1;console.log("-----------------");
gun.get('g/n/f').path('data').path('a').any(function(b,a){
console.log(":D", a,b);
expect(a).to.be(1);
done();
});
});
return;
return;
return;
return;
return;
return;
return;
return;
return;
return;
return;
return;
return;
return;
return;
return;
return;
return;
return;
return;
return;
return;
return;
return;
return;
return;
return;
return;
return;
it("get map path val", function(done){ // Terje's bug
var gun = Gun();
var ctx = {l: -1, d: 0};
var passengers = gun.get('passengers/path').not(function(key){
this.put({randombob: {
name: "Bob",
location: {'lat': '37.6159', 'lng': '-128.5'},
direction: '128.2'
}}).key(key);
});
passengers.map().path('location.lng').once(function(val, field){
//passengers.map().path('location.lng').on(function(val, field){
console.log("******", field, val);
expect(field).to.be('lng');
if(ctx.l){
expect(val).to.be('-128.5');
} else {
expect(val).to.eql('f-128.5');
}
ctx.l++;
if(ctx.l){ done() }
});
setTimeout(function(){
console.debug.i=1;console.log("-------------------------------------");
passengers.put({randomfred: {
name: "Fred",
location: {'lat': 'f37.6159', 'lng': 'f-128.5'},
direction: 'f128.2'
}});
},300);
});
it("FILT ER FILTER", function(done){
var g = Gun();
var a = gun.put({});
var b = gun.put({age: 19, name: "bob"});
console.debug.i=1;console.log("~~~~~~~~~~~~~~~~~~~~~~~~~");
(window.ALICE = a.filter()).path('spouse.name').on(function(a,b){
console.log("1", b,a);
});
a.put({age: 24, name: "alice", spouse: {name: "carl"}});
return;
b.filter().on(function(a,b){
console.log("2", b,a);
});
});
it("map path before", function(done){
var gun = Gun();
var g = gun.put({a: {x:1}, b: {x:2}, c: {x:3}});
var c = 0;
var m = g.map().path('x').on(function(v,f){
console.log("*********************", f,v);
if(3 === ++c && 3 === v){
done();
}
});
});
it("map path", function(done){
var gun = Gun();
var g = gun.get('map/path/ing');
var c = 0;
var m = g.map().path('x').on(function(v,f){
if(3 === ++c && 3 === v){
done();
}
});
g.put({a: {x:1}, b: {x:2}, c: {x:3}});
});
it("map path path", function(done){
var gun = Gun();
var g = gun.get('map/path/path/ing');
var c = 0;
var m = g.map().path('x.y').on(function(v,f){
//console.log("Hmmmm", f,v);
if(3 === ++c && 3 === v){
done();
}
});
g.put({a: {x:{y:1}}, b: {x:{y:2}}, c: {x:{y:3}}});
});
it("put path deep val -> path val", function(done){ // Terje's bug
var gun = Gun();
gun.put({you: {have: {got: {to: {be: {kidding: "me!"}}}}}}).path('you.have.got.to.be').once(function(val, field){
expect(val.kidding).to.be('me!');
this.path('kidding').once(function(val){
expect(val).to.be('me!');
done();
});
});
});
it("get set path put, map path val -> path val", function(done){ // Terje's bug
var gun = Gun();
var ctx = {l: -1, d: 0};
var passengers = gun; //.get('passengers/set/path');
passengers = passengers.put({randombob: {name: 'Bob', direction: {}}});
passengers.path('randombob.direction', function(err, ok, field){
}).put({lol: {just: 'kidding', dude: '!'}});
passengers.map().path('direction.lol').once(function(val){
this.path('just').once(function(val){
expect(val).to.be('kidding');
}).back().path('dude').once(function(val){
expect(val).to.be('!');
done();
});
})
});
it('path rel should not slowdown', function(done){
this.timeout(5000);
var gun = Gun(/*gopt*/).put({
history: {}
});
var prev, diff, max = 100, total = 20, largest = -1, gone = {};
var run = 0;
gun.path('history').map(function(entry, index){
//if(!entry){ return } // TODO: BUG! KNOWN BUG!!!!!!! FIX!!!!!
++run;
var i = run+'';
expect(i).to.be(index+'');
expect(i).to.be(entry.x+'');
expect(i).to.be(entry.y+'');
expect(i).to.be(entry.direction+'');
expect(entry.axis).to.be.ok();
expect(entry.direction).to.be.ok();
if(run > total){
if(done.c){ return }
setTimeout(function(){
done();
done.c=true;
},20);
}
return;
//console.log("THE GRAPH\n", gun.__.graph);
//expect(gone[index]).to.not.be.ok();
gone[index] = diff;
diff = Gun.time.is() - (entry.time || prev);
largest = (largest < diff)? diff : largest;
//console.log('turn', turns, 'index', index, 'diff', diff, 'largest', largest);
expect(diff > max).to.not.be.ok();
});
var turns = 0;
var many = setInterval(function(){
if(turns > total || diff > (max + 5)){
//console.log("was it", turns > total, 'or', diff > (max + 5));
clearTimeout(many);
return;
expect(Gun.num.is(diff)).to.be.ok();
if(done.c){ return } done(); done.c = 1;
return;
}
prev = Gun.time.is();
turns += 1;
var val = {
x: turns,
y: turns,
axis: 'y',
direction: turns,
time: prev
}
var put = {}; put[turns] = val;
gun.put({history: put});
//gun.path(['history', turns += 1]).put({
},1);
});
it.skip('paths rel should not slowdown', function(done){ // TODO: NEED TO ADD THIS NEW TEST!
this.timeout(5000);
//this.timeout(60000);
//Gun.log.debug = 1; console.log("~~~~~ START ~~~~~~");
var gun = Gun(gopt).put({
history: {}
});
//console.log("-------- DATA SET UP -----------");
var prev, diff, max = 100, total = 100, largest = -1, gone = {};
gun.path('history').map(function(entry, index){
//if(!entry){ return } // TODO: BUG! KNOWN BUG!!!!!!! FIX!!!!!
//console.log("WAT", index, entry);
//console.log("THE GRAPH\n", gun.__.graph);
//expect(gone[index]).to.not.be.ok();
gone[index] = diff;
diff = Gun.time.is() - (entry.time || prev);
largest = (largest < diff)? diff : largest;
console.log('turn', turns, 'index', index, 'diff', diff, 'largest', largest);
expect(diff > max).to.not.be.ok();
});
var turns = 0;
//console.log("------------ PATH MAP SET UP --------------");
var many = setInterval(function(){
if(turns > total || diff > (max + 5)){
clearTimeout(many);
expect(Gun.num.is(diff)).to.be.ok();
if(done.c){ return } done(); done.c = 1;
return;
}
prev = Gun.time.is();
Gun.log.base = Gun.log.ref = Gun.log.fer = prev;
//if(turns === 0){ Gun.log.debug = 1; console.log("~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~"); }
//console.log("-------------- ", turns + 1, "-----------------");
var val = {
TURN: turns + 1,
x: 1,
y: 1,
axis: 'y',
direction: 1,
time: prev
}
//var put = {}; put[turns += 1] = val;
//gun.put({history: put});
gun.path(['history', turns += 1]).put(val);
},1);
});
it("gun get on, later gun put key", function(done){
var gun = Gun();
var keyC = gun.get('keyC').on(function(val){
expect(val.hello).to.be('world');
if(done.done){ return }
done.done = true;
done();
});
setTimeout(function(){
gun.put({hello: 'world'}).key('keyC');
}, 100);
});
it('gun get put, sub path put, original val', function(done){ // bug from Jesse working on Trace //
var gun = Gun(gopt).get('players');
gun.put({
taken: true,
history: {0: {}, 1: {}}
});
gun
.path('history')
.put(null)
.back()
.path('taken')
.put(false)
// TODO: BUG! There is a variation of this, where we just do `.val` rather than `gun.val` and `.val` by itself (chained off of the sub-paths) doesn't even get called. :(
gun.on(function(players){ // this val is subscribed to the original put and therefore does not get any of the sub-path listeners, therefore it gets called EARLY with the original/old data rather than waiting for the sub-path data to "finish" and then get called.
expect(players.history).to.be(null);
expect(players.taken).to.be(false);
if(done.c){ return } done(); done.c = 1;
});
});
it("gun put recursive path slowdown", function(done){
this.timeout(5000);
var gun = Gun();
gun.__.opt.wire.put = null;
function put(num, t) {
var now = new Date().getTime();
var cb;
for (var i = 1; i <= num; i++) {
if (i === num) {
cb = function (err, ok) {
console.log(num + 'ops: ' + (new Date().getTime() - now)/1000 + 's');
}
}
Gun.ify({ //hello: 'world'}, cb);
deeply: {
nested: i
}
})(cb);
}
return new Date().getTime() - now;
}
/*
put(1);
put(2);
put(10);
put(50);
put(100);
put(1000);
put(5000);*/
put(1000, true);
var gun2 = Gun();
gun2.__.opt.wire.put = null;
function put2(num, t) {
var now = new Date().getTime();
var cb;
for (var i = 1; i <= num; i++) {
if (i === num) {
cb = function () {
console.log(num + ' API ops: ' + (new Date().getTime() - now)/1000 + 's');
t && done();
}
}
gun2.put({ //hello: 'world'}, cb);
deeply: {
nested: i
}
}, cb);
}
return new Date().getTime() - now;
}
Gun.log.start = Gun.time.is();
put2(1);
put2(1000); // TODO: BUG! Interesting! If you add another 0 it causes a stack overflow! If I make Gun.time.now() not recurse then it runs but takes 4x as long. Even on the 10k ops there seems to be about a 4x overhead with the API versus raw serializer.
put2(1, true);
//put2(2);
//put2(10);
//put2(50);
//put2(100, true);
//put2(5000, true);
} );
it('choke time.now by using a while loop', function(){
var i = 10; //100000; // causes an overflow.
while(--i){
Gun.time.now();
}
});
/* // TODO: These tests should be deleted.
it("test timeout", function(done){ return done();
var i = 1000, start = Date.now();
while(i--){
setTimeout(function(){
console.log("ended in", (Date.now() - start)/1000);
},0);
}
return;
Gun.schedule(start, function(){
console.log("ended in", (Date.now() - start)/1000);
});
setImmediate(function(){
console.log("ended in", (Date.now() - start)/1000);
});
process.nextTick(function(){
console.log("ended in", (Date.now() - start)/1000);
});
});
it("test assignment", function(done){
var env = {graph: {}};
function speed(other){
var i = 10000;
while(i--){
var $ = {soul: Gun.text.random()};
var at = {node: {_: {}}};
var obj = {
deeply: {
nested: 'lol'
}
}
env.graph[at.node._['#'] = at.soul = $.soul] = at.node
}
}
var start = Date.now();
speed();
console.log('wat', (Date.now() - start)/1000);
});
it("test fn call", function(done){
function speed(i, cb){
var r = 0;
while(i--){
if(cb){
cb(i);
} else {
r += i;
}
}
}
var start = Date.now();
speed(100000000);
console.log('no fn', (Date.now() - start)/1000);
var start = Date.now(), r = 0;
speed(100000000, function(i){ r += i });
console.log('w/ fn', (Date.now() - start)/1000);
var start = Date.now(), r = 0;
function foo(i){ r += i }
speed(100000000, foo);
console.log('w/ named fn', (Date.now() - start)/1000);
});
it("gun put recursive path slowdown MUTANT TEST", function(done){
this.timeout(30000);
Gun.chain.put = function(val, cb, opt){
var gun = this.chain(), obj;
var drift = Gun.time.now(), call = {};
cb = cb || function(){};
gun._.at('soul').event(
//(
function($){
var chain = $.$ || gun;
var ctx = {}, obj = val, $ = Gun.obj.copy($);
var hash = $.field? $.soul + $.field : ($.from? $.from + ($.at || '') : $.soul);
if(call[hash]){ return }
gun.__.meta($.soul).put = true;
call[hash] = true;
if(Gun.is.once(obj)){
if($.from && $.at){
$.soul = $.from;
$.field = $.at;
} // no else!
if(!$.field){
return cb.call(gun, {err: Gun.log("No field exists for " + (typeof obj) + "!")});
} else
if(gun.__.graph[$.soul]){
ctx.tmp = {};
ctx.tmp[ctx.field = $.field] = obj;
obj = ctx.tmp;
} else {
return cb.call(gun, {err: Gun.log("No node exists to put " + (typeof obj) + " in!")});
}
}
if(Gun.obj.is(obj)){
if($.field && !ctx.field){
ctx.tmp = {};
ctx.tmp[ctx.field = $.field] = obj;
obj = ctx.tmp;
}
Gun.ify(obj || val, function(env, cb){
var at;
if(!env || !(at = env.at) || !env.at.node){ return }
if(!at.node._){
at.node._ = {};
}
if(!Gun.node.soul(at.node)){
if(obj === at.obj){
env.graph[at.node._['#'] = at.soul = $.soul] = at.node;
cb(at, at.soul);
} else {
function path(err, data){
if(at.soul){ return }
at.soul = Gun.node.soul(data) || Gun.node.soul(at.obj) || Gun.roulette.call(gun); // TODO: refactor Gun.roulette!
env.graph[at.node._['#'] = at.soul] = at.node;
//var start = performance.now();
cb(at, at.soul);
//first = performance.now() - start;(first > .05) && console.log('here');
};
($.empty && !$.field)? path() : chain.back().path(at.path || [], path, {once: true, end: true}); // TODO: clean this up.
}
//var diff1 = (first - start), diff2 = (second - first), diff3 = (third - second);
//(diff1 || diff2 || diff3) && console.log(diff1, ' ', diff2, ' ', diff3);
}
if(!at.node._[Gun._.state]){
at.node._[Gun._.state] = {};
}
if(!at.field){ return }
at.node._[Gun._.state][at.field] = drift;
})(function(err, ify){
//console.log("chain.put PUT <----", ify.graph, '\n');
if(err || ify.err){ return cb.call(gun, err || ify.err) }
if(err = Gun.union(gun, ify.graph).err){ return cb.call(gun, err) }
if($.from = Gun.val.link.is(ify.root[$.field])){ $.soul = $.from; $.field = null }
Gun.obj.map(ify.graph, function(node, soul){ Gun.union(gun, Gun.union.pseudo(soul)) });
gun._.at('soul').emit({soul: $.soul, field: $.field, key: $.key, PUT: 'SOUL', WAS: 'ON'}); // WAS ON
//return cb(null, true);
if(Gun.fn.is(ctx.hook = gun.__.opt.hooks.put)){
ctx.hook(ify.graph, function(err, data){ // now iterate through those nodes to a persistence layer and get a callback once all are saved
if(err){ return cb.call(gun, err) }
return cb.call(gun, null, data);
}, opt);
} else {
//console.Log("Warning! You have no persistence layer to save to!");
cb.call(gun, null); // This is in memory success, hardly "success" at all.
}
});
}
})
gun._.at('soul').emit({soul: Gun.roulette.call(gun), field: null, empty: true});
return gun;
}
var gun = Gun(); //.get('bug').put({});
gun.__.opt.hooks.put = null;
function put(num, t) {
var now = new Date().getTime();
var cb;
for (var i = 1; i <= num; i++) {
if (i === num) {
cb = function (err, ok) {
console.log(num + 'MUTANT ops: ' + (new Date().getTime() - now)/1000 + 's');
t && done();
}
}
gun.put({ //hello: 'world'}, cb);
deeply: {
nested: i
}
}, cb);
}
return new Date().getTime() - now;
}
//put(1, true);
//put(2);
//put(10);
//put(50);
//put(100);
//put(1000);
//put(5000);
put(10000, true);
});
*/
it("gun get empty set, path not -> this put", function(done){ // Issue #99 #101, bug in survey and trace game.
var test = {c: 0}, u;
var gun = Gun();
var game = gun.get('some/not/yet/set/put/thing').not(function(key){
gun.put({alias: {}}).key(key);
});//.set();
var me = game.path('alias').on(function(val){
if(!done.put){ return }
expect(val).to.not.be(u);
expect(val.a).to.be('b');
var meid = Gun.node.soul(val);
var self = this;
/*
expect(self === game).to.not.be.ok();
expect(self === me).to.be.ok();
*/
if(done.c){ return } done(); done.c = 1;
});
setTimeout(function(){
done.put = true;
me.put({a: 'b'});
},100);
});
it("gun get empty set path empty later path put multi", function(done){ // Issue #99 #101, bug in survey and trace game. // ctx.halt
done.c = 0;
var gun = Gun();
var data = gun.get('some/not/yet/set/put/thing/2');
var path = data.path('sub');
function put(d, t, f){
setTimeout(function(){
path.put(d, function(err, ok){
expect(err).to.not.be.ok();
done.c++;
if(f && done.c >= 3){
done();
}
});
},t || 10);
};
put({on: 'bus', not: 'transparent'});
put({on: null, not: 'torrent'}, 200);
put({on: 'sub', not: 'parent'}, 250, true);
});
it("ToDo", function(done){ // Simulate ToDo app!
var gun = Gun().get('example/todo/data');
gun.on(function renderToDo(val){
if(done.done){ return }
if(done.clear){
done.done = true;
expect(val[done.id]).to.not.be.ok();
return done();
}
delete val._;
Gun.obj.map(val, function(val, field){ return done.id = field; });
expect(val[done.id]).to.be('groceries');
});
setTimeout(function(){ // form submit
gun.path('random1').put("groceries");
setTimeout(function(){ // clear off element
done.clear = true;
gun.path(done.id).put(null);
},100);
},200);
});
it("gun put null path on put sub object", function(done){ // consensus4's bug
done.c = 1;
var gun = Gun();
//Gun.log.verbose = true;
var game = gun.put({board: null, teamA: null, teamB: null, turn: null}).key('the/game');
game.path('board').on(function(board, field){
expect(field).to.be('board');
if(done.c === 1){
expect(board).to.not.be.ok();
}
if(done.c === 2){
if(!board[11] || !board[22] || !board[33]){ return }
done.c++;
delete board._;
expect(board).to.be.eql({11: ' ', 22: ' ', 33: 'A'});
done();
}
});
setTimeout(function(){
done.c++;
game.put({board: {11: ' ', 22: ' ', 33: 'A'}});
},100);
});
it("get init put map -> put, foreach gun path map", function(done){ // replicate Jesse's Trace game bug
done.c = 0;
var gun = Gun(gopt).opt({init: true})
.get('players').init()
.put({
0: {
num: 0
},
1: {
num: 1
},
2: {
num: 2
},
3: {
num: 3
}
}, function(err,ok){
expect(done.c++).to.be(0);
}).once(function(p){
done.p = Gun.node.soul(p);
done.m = Gun.val.link.is(p[0]);
expect(Gun.val.link.is(p[0])).to.be.ok();
expect(Gun.val.link.is(p[1])).to.be.ok();
expect(Gun.val.link.is(p[2])).to.be.ok();
expect(Gun.val.link.is(p[3])).to.be.ok();
})
var players = [], me;
gun.map(function (player, number) {
players[number] = player;
players[number].history = [];
if (!player.taken && !me) {
this.put({
taken: true,
history: {
0: {x: 1, y: 2}
}
}, function(err,ok){});
me = number;
}
});
Gun.list.map([0, 1, 2, 3], function (player, number) {
number = number - 1;
gun
.path(number + '.history')
.map(function (entry, logNum) {
done.c++;
players[number].history[logNum] = entry;
expect(entry.x).to.be(1);
expect(entry.y).to.be(2);
setTimeout(function(){
expect(done.c).to.be(2);
done();
},100);
});
});
});
it("gun get path empty val", function(done){ // flip flop bug
done.c = 0;
var u;
var gun = Gun(gopt);
var game = gun.get('game1/players');
var me = game.path('player1').once(function(val){
if(!done.c){ done.fail = true }
expect(val).to.not.be(u);
expect(val.x).to.be(0);
expect(val.y).to.be(0);
expect(done.fail).to.not.be.ok();
done();
});
setTimeout(function(){
done.c++;
expect(done.fail).to.not.be.ok();
me.put({x: 0, y: 0});
},10);
});
it("gun get path empty on", function(done){
done.c = 0;
var u;
var gun = Gun(gopt);
var game = gun.get('game2/players');
var me = game.path('player2').on(function(val){
if(!done.c){ done.fail = true }
expect(done.fail).to.not.be.ok();
expect(val).to.not.be(u);
if(done.done || !val.x || !val.y){ return } // it is okay if ON gets called many times, this protects against that.
// TODO: although it would be nice if we could minimize the amount of duplications. (may not happen to after 1.0.0)
expect(val.x).to.be(1);
expect(val.y).to.be(1);
done.done = true;
done();
});
setTimeout(function(){
done.c++;
expect(done.fail).to.not.be.ok();
me.put({x: 1, y: 1});
},10);
});
it("gun get path empty not", function(done){
var u;
var gun = Gun(gopt).opt({init: true})
var game = gun.get('game3/players').init();
var me = game.path('player3').not(function(field){
expect(field).to.be('player3');
done();
});
});
it("gun get path empty init", function(done){
var u;
var gun = Gun(gopt).opt({init: true});
var game = gun.get('game4/players').init();
var me = game.path('player4').init().path('alias').init().put({oh: 'awesome'}).once(function(val, field){
expect(val.oh).to.be('awesome');
expect(field).to.be('alias');
done();
})
});
it("no invalid graph", function(done){
var gun = Gun({wire:{
put: function(graph){
expect(Gun.is.graph(graph)).to.be.ok();
if(done.c){ return } if(done.on){ done(); done.c = 1 }
}
}}).get('example/todo/data/graph');
gun.on(function renderToDo(val){
done.on = true;
});
setTimeout(function(){
gun.path(Gun.text.random()).put('hoorah');
},100)
});
it("no undefined field", function(done){
var gun = Gun();
var chat = gun.get('example/chat/data/graph/field').not(function(key){
gun.put({1: {who: 'Welcome', what: "to the chat app!", when: 1}}).key(key);
});
chat.map().once(function renderToDo(val, field){
expect(field).to.be.ok();
expect(val.who).to.be.ok();
expect(val.when).to.be.ok();
expect(val.what).to.be.ok();
if(done.c >= 2){ return }
if(done.c === 1){ done() }
done.c = done.c || 0;
done.c += 1;
});
setTimeout(function(){
var msg = {};
msg.when = Gun.time.is();
msg.what = "lol!";
msg.who = "Alice";
chat.path(msg.when + '_' + Gun.text.random(4)).put(msg);
},100);
});
/* // This test didn't work for what I was wanting to test :(, will either remove it or modify it if I think of a clever solution to test what I want to test.
it("simulate json app", function(done){
var peers = {};
peers.server = Gun();
function wipeServer(){
peers.server = Gun();
}
var gopt = {wire:{
put: function(graph, cb){
Gun.union(peers.server, graph);
cb(null);
}
,get: function(lex, cb){
setTimeout(function(){
var soul = lex['#'];
if(peers.localStorage){
var g = peers.localStorage;
console.log("VIA LOCALSTORAGE!", lex, g[soul]);
if(g[soul]){
var n = g[soul];
cb(null, n);
cb(null, Gun.is.node.ify({}, soul));
cb(null, {});
}
}
setTimeout(function(){
var graph = peers.server.__.graph;
console.log("VIA the SERVER!!", lex, graph[soul]);
if(!graph[soul]){
cb(null);
cb(null, {});
return;
}
var node = graph[soul];
cb(null, node);
cb(null, Gun.is.node.ify({}, soul));
cb(null, {});
},5);
},5);
}
}}
peers.g = Gun(gopt);
function reload(){
peers.localStorage = Gun.obj.copy(peers.g.__.graph);
peers.g2 = Gun(gopt);
}
var ref = peers.g.get('example/json/data/test');
setTimeout(function(){
ref.path('hello').put("value");
setTimeout(function(){
wipeServer();
reload();
setTimeout(function(){
Gun.log.debug = 1; console.log("~~~~~~~~~~~~~~~~~~~");
var ref = peers.g2.get('example/json/data/test');
ref.on(function(data){
console.log("on!", data);
});
},100);
},100);
},100);
});
*/
it("simulate chat app", function(done){
var server = Gun();
var gopt = {wire:{
put: function(graph, cb){
Gun.union(server, graph);
cb(null);
}
,get: function(lex, cb){
setTimeout(function(){
var soul = lex['#'];
var graph = server.__.graph;
//console.log('server replying', soul, graph);
if(!graph[soul]){
//console.log("replying to Alice...", null);
cb(null);
cb(null, {});
return;
}
var node = graph[soul];
//console.log("replying to Bob...", node);
cb(null, node);
cb(null, Gun.is.node.ify({}, soul));
cb(null, {});
},5);
}
}}
var gun = Gun(gopt);
var chat = gun.get('example/chat/data/graph/field').not(function(key){
gun.put({1: {who: 'Welcome', what: "to the chat app!", when: 1}}).key(key);
});
chat.map().once(function renderToDo(val, field){
//console.log("ALICE", field, val);
expect(field).to.be.ok();
expect(val.who).to.be.ok();
expect(val.when).to.be.ok();
expect(val.what).to.be.ok();
});
setTimeout(function(){
var gun2 = Gun(gopt);
//Gun.log.debug =1; console.log("~~~~~~~~~~~~~~~~~~~~~~~~~~~~~");
var chat2 = gun2.get('example/chat/data/graph/field').not(function(key){
//console.log("BOB's key", key);
gun2.put({1: {who: 'Welcome', what: "to the chat app!", when: 1}}).key(key);
});
chat2.map().once(function renderToDo(val, field){
//console.log("BOB", field, val);
expect(field).to.be.ok();
expect(val.who).to.be.ok();
expect(val.when).to.be.ok();
expect(val.what).to.be.ok();
done();
});
},100);
});
it.skip("gun path via gun path", function(done){ // TODO: Future feature?
var gun = Gun();
var book = gun.put({ name: 'Potato Cooking' });
var author = gun.put({ name: 'Bob Bobson' });
author.path(book.path('name')).put(book);
});
it("gun set", function(done){
var gun = Gun();
var users = gun.get('users/s');
var alice = gun.put({name: 'alice', birth: Math.random()}).key('person/alice');
var bob = gun.put({name: 'bob', birth: Math.random()}).key('person/bob');
var carl = gun.put({name: 'carl', birth: Math.random()}).key('person/carl');
var dave = gun.put({name: 'dave', birth: Math.random()}).key('person/dave');
// Test set with new object
var alan = users.set({name: 'alan', birth: Math.random()}).key('person/alan');
alan.once(function(alan) {
// Test set with node
dave.path('friends').set(alan);
});
users.set(alice);
users.set(bob);
users.set(carl);
users.set(dave);
alice.path('friends').set(bob).back().set(carl);
bob.path('friends').set(alice);
dave.path('friends').set(alice).back().set(carl);
var team = gun.get('team/lions').put({name: "Lions"});
team.path('members').set(alice);
team.path('members').set(bob);
team.path('members').set(alan); // Test set with set
alice.path('team').put(team);
bob.path('team').put(team);
dave.path('friends').map().path('team.members').map().once(function(member){
//console.log("Dave's friend is on a team that has", member.name, "on it.");
if('alice' === member.name){
done.alice = true;
} else
if('bob' === member.name){
done.bob = true;
} else
if('alan' === member.name){
done.alan = true;
} else
{
expect(member).to.not.be.ok();
}
if(done.alice && done.bob && done.alan){
setTimeout(function(){
done();
},10);
}
});
});
it("get context", function(done){ // TODO: HUH?????? This was randomly causing errors?
var gun = Gun();
var ref = gun.get('ctx/lol').get('ctx/foo').put({hello: 'world'});
gun.get('ctx/lol').once(function(implicit){
done.fail = true;
expect(implicit).to.not.be.ok();
});
gun.get('ctx/lol').not(function(){
done.please = true;
});
gun.get('ctx/foo').once(function(data){
expect(data.hello).to.be('world');
expect(done.fail).to.not.be.ok();
expect(done.please).to.be.ok();
done();
});
});
it.skip("chaining val", function(done){ // Not implemented yet!
var gun = Gun();
gun.get('users/cv').set(gun.put({name: 'alice'}));
gun.get('users/cv').set(gun.put({name: 'bob'}));;
gun.get('users/cv').once().map(function(person){
if(person.name === 'alice'){
done.alice = true;
}
if(person.name === 'bob'){
done.bob = true;
}
if(person.name === 'carl'){
done.carl = true;
}
});
gun.get('users/cv').set(gun.put({name: 'carl'}));
setTimeout(function(){
console.log('wha?', done.alice, done.bob, done.carl);
expect(done.alice).to.be.ok();
expect(done.bob).to.be.ok();
expect(done.carl).to.not.be.ok();
done();
},10);
});
it.skip('Deep async change not updating', function (done) { // Issue #167 TODO: NEEDS TO BE ADDED TO 0.5 BRANCH!
// object nested three layers deep
// must be at least three layers
var obj = { 1: { 2: { data: false } } }
// define gun and place the deep object
gun = Gun().get('deep change').put(obj)
// listen for changes
Gun.log.debug = 1; console.log("------------------");
gun.path('1.2.data').on(function (data) {
console.log("??????", data);
if (data) {
// gun will never receive the "true" update
done();
}
})
// asynchronously set data
// synchronous deviations will succeed
setTimeout(function () {
obj[1][2].data = true
gun.put(obj);
}, 50)
});
it('should allow more than 2 items depthwise', function (done) { // Issue #186
var gun = Gun();
var list = gun.get('list');
// create a list two layers deep
list.put({
depth: 1,
next: {
depth: 2
}
});
//Gun.log.verbose=true;Gun.log.debug=1;console.log("----------------------");
// append a third item
list.path('next').put({
to: {
depth: 3
}
});
setTimeout(function(){
//list.path('next').once('wat');
//console.log("!!!!!!", gun.__.graph);
// try to read the third item
list.path('next.to').once(function () { // TODO: BUG! If this is 'next.next' as with the data, then it fails.
done();
});
},100);
});
it("Batch put status update not save", function(done){ // TODO: ADD TO 0.5 BRANCH. Stefdv's bug.
var obj = {
a: 1,
b: 2,
c: 3,
d: 4,
e: 5,
f: 6,
g: 7,
h: 8,
i: 9,
j: 10,
k: 11,
l: 12,
m: 13,
n: 14,
o: 15,
p: 16,
q: 17,
r: 18,
s: 19,
t: 20
}
var bsmi = {
group1: {
item1: {
10: Gun.obj.copy(obj)
}
}/*,
group2: {
item2: {
10: Gun.obj.copy(obj)
}
}*/
}
var gun = Gun();
var BSMI = gun.get('bsmi').put(bsmi);
// path is <group><itemId><powerRail>
//BSMI is a set holding all items
//var allPaths = ["1116.1116-A7001.10","1354.1354-E1930.10"]
var allPaths = ["group1.item1.10"];//,"group2.item2.10"]
allPaths.forEach(function(path) {
BSMI.path(path).put({status:false});
});
setTimeout(function(){
BSMI.path(allPaths[0]).once(function(a,b,c){
expect(a.a).to.be(1);
expect(a.b).to.be(2);
expect(a.c).to.be(3);
expect(a.d).to.be(4);
expect(a.e).to.be(5);
expect(a.f).to.be(6);
expect(a.g).to.be(7);
expect(a.h).to.be(8);
expect(a.i).to.be(9);
expect(a.j).to.be(10);
expect(a.k).to.be(11);
expect(a.l).to.be(12);
expect(a.m).to.be(13);
expect(a.n).to.be(14);
expect(a.o).to.be(15);
expect(a.p).to.be(16);
expect(a.q).to.be(17);
expect(a.r).to.be(18);
expect(a.s).to.be(19);
expect(a.t).to.be(20);
expect(a.status).to.be(false);
done();
});
},100);
});
it("Don't put on parents", function(done){ // TODO: ADD TO 0.5 BRANCH! // Another Stefdv find.
var test = gun.get('test');
test.path('try.this.at.lvl4').put({msg:'hoi'})
test.once(function(node,b){
delete node._;
expect(Gun.obj.empty(node, 'try')).to.be.ok();
node = Gun.obj.copy(gun.__.graph[Gun.val.link.is(node.try)]);
delete node._;
expect(Gun.obj.empty(node, 'this')).to.be.ok();
node = Gun.obj.copy(gun.__.graph[Gun.val.link.is(node.this)]);
delete node._;
expect(Gun.obj.empty(node, 'at')).to.be.ok();
node = Gun.obj.copy(gun.__.graph[Gun.val.link.is(node.at)]);
delete node._;
expect(Gun.obj.empty(node, 'lvl4')).to.be.ok();
node = Gun.obj.copy(gun.__.graph[Gun.val.link.is(node.lvl4)]);
delete node._;
expect(Gun.obj.empty(node, 'msg')).to.be.ok();
expect(node.msg).to.be('hoi');
done();
});
});
it("Deep not fails to fire", function(done){ // @d3x0r's bug!
var gun = Gun().get("org.d3x0r.voxelarium.local." + Gun.text.random());
var player = gun.path( "player" );
player.path("id").not(function(){
done.not = true;
//console.log("Not is run!");
var id = 'fluffy';
var world = 0;
player.path("id").put(id);
player.path("world_id").put(world);
}).once(function(data){
//console.log("we have value!", data);
expect(done.not).to.be.ok();
expect(data).to.be('fluffy');
done();
});
});
/*
depp.on(log).path('spouse').on(log).path('pet').on(log);
// 0) Depp & Heide & dog
// 1) dog
// 2) cat
// 3) cat
// 4) Julie & cat
depp.path('spouse.pet.name').on(log).put('pearls');
depp.path('spouse.pet.name').put('paws').on(log);
depp.path('spouse.pet.name').on(log).not(log);
// 0: fluffy
// 1: fluff
// 3: bacon
// 9: `.not`
depp.path('spouse.pet.name').once().on(log);
// 0: fluffy
// 1: fluff
*/
});
describe('localStorage', function(){
it("err", function(done){
this.timeout(9000);
var localStorage = localStorage || {clear:function(){}};
localStorage.clear();
var gun = Gun();
var text = String.random(1024 * 1024 * 6);
gun.put({i: text}, function(ack){
var err = ack.err, ok = ack.ok;
if(done.c){ return }
if(!err){ return done() }
var text = "If you are seeing this message, it means the localStorage error was caught successfully rather than it crashing and stopping replication to peers. Also, the error is now reported back to you via the put callback. Here it is!";
localStorage.clear();
done(); done.c = 1;
});
});
it("ack", function(done){
this.timeout(9000);
var localStorage = localStorage || {clear:function(){}};
localStorage.clear();
var gun = Gun();
var i = 999, obj = {}; while(--i){ obj[i] = String.random(99) }
//console.log("save:", obj);
gun.get('lSack').put(obj, function(ack){
//console.log("ack:", ack)
done(); done.c = 1;
});
});
});
describe('Streams', function(){
console.log("TODO: BUG! Upgrade UNION tests to new internal API!");
return;
var gun = Gun(), g = function(){
return Gun({wire: {get: ctx.get}});
}, ctx = {gen: 9, extra: 100, network: 2};
it('prep hook', function(done){
this.timeout(ctx.gen * ctx.extra);
var peer = Gun(), ref;
ctx.get = function(key, cb){
var c = 0;
cb = cb || function(){};
key = key['#'];
if('big' !== key){ return cb(null) }
setTimeout(function badNetwork(){
c += 1;
var soul = Gun.node.soul(ref);
var graph = {};
var data = /*graph[soul] = */ {_: {'#': soul, '>': {}}};
if(!ref['f' + c]){
return cb(null, data), cb(null, {});
}
data._[Gun._.state]['f' + c] = ref._[Gun._.state]['f' + c];
data['f' + c] = ref['f' + c];
cb(null, data);
setTimeout(badNetwork, ctx.network);
},ctx.network);
}
ctx.get.fake = {};
for(var i = 1; i < (ctx.gen) + 1; i++){
ctx.get.fake['f'+i] = i;
ctx.length = i;
}
ctx.get.fake = Gun.is.node.ify(ctx.get.fake, 'big');
var big = peer.put(ctx.get.fake).once(function(val){
ref = val;
ctx.get({'#': 'big'}, function(err, graph){
if(Gun.obj.empty(graph)){ done() }
});
gun.opt({wire: {get: ctx.get}});
});
});
it('map chain', function(done){
var set = gun.put({a: {here: 'you'}, b: {go: 'dear'}, c: {sir: '!'} });
set.map().once(function(obj, field){
if(obj.here){
done.a = obj.here;
expect(obj.here).to.be('you');
}
if(obj.go){
done.b = obj.go;
expect(obj.go).to.be('dear');
}
if(obj.sir){
done.c = obj.sir;
expect(obj.sir).to.be('!');
}
if(done.a && done.b && done.c){
done();
}
});
});
it('map chain path', function(done){
var set = gun.put({
a: {name: "Mark",
pet: {coat: "tabby", name: "Hobbes"}
}, b: {name: "Alice",
pet: {coat: "calico", name: "Cali"}
}, c: {name: "Bob",
pet: {coat: "tux", name: "Casper"}
}
});
set.map().path('pet').once(function(obj, field){
if(obj.name === 'Hobbes'){
done.hobbes = obj.name;
expect(obj.name).to.be('Hobbes');
expect(obj.coat).to.be('tabby');
}
if(obj.name === 'Cali'){
done.cali = obj.name;
expect(obj.name).to.be('Cali');
expect(obj.coat).to.be('calico');
}
if(obj.name === 'Casper'){
done.casper = obj.name;
expect(obj.name).to.be('Casper');
expect(obj.coat).to.be('tux');
}
if(done.hobbes && done.cali && done.casper){
done();
}
});
});
it('get big on', function(done){
this.timeout(ctx.gen * ctx.extra);
var test = {c: 0, last: 0};
g().get('big').on(function(val){
if(test.done){ return console.log("hey yo! you got duplication on your ons!"); }
delete val._;
if(val['f' + (test.last + 1)]){
test.c += 1;
test.last += 1;
}
var obj = {};
for(var i = 1; i < test.c + 1; i++){
obj['f'+i] = i;
}
expect(val).to.eql(obj);
if(test.c === ctx.length){
test.done = true;
done();
}
});
});
it('get big on delta', function(done){
this.timeout(ctx.gen * ctx.extra);
var test = {c: 0, seen: {}};
g().get('big').on(function(val){
delete val._;
if(test.seen['f' + test.c]){ return }
test.seen['f' + test.c] = true;
test.c += 1;
var obj = {};
obj['f' + test.c] = test.c;
expect(val).to.eql(obj);
if(test.c === ctx.length){
done();
}
}, true);
});
it('get val', function(done){
this.timeout(ctx.gen * ctx.extra);
g().get('big').once(function(obj){
delete obj._;
expect(obj.f1).to.be(1);
expect(obj['f' + ctx.length]).to.be(ctx.length);
var raw = Gun.obj.copy(ctx.get.fake);
delete raw._;
expect(obj).to.be.eql(raw);
Gun.log.debug = 0;
done();
});
});
it('get big map val', function(done){
this.timeout(ctx.gen * ctx.extra);
var test = {c: 0, seen: {}};
g().get('big').map().once(function(val, field){
if(test.seen[field]){ return }
test.seen[field] = true;
delete val._;
expect(field).to.be('f' + (test.c += 1));
expect(val).to.be(test.c);
if(test.c === ctx.length){
done();
}
});
});
it('val emits all data', function(done){ // bug in chat app
var chat = Gun().get('example/chat/data').not(function(){
this.put({1: {who: 'Welcome', what: "to the chat app!", when: 0}}).key('example/chat/data');
});
chat.put({random1: {who: 'mark', what: "1", when: 1}});
chat.put({random2: {who: 'mark', what: "2", when: 2}});
chat.put({random3: {who: 'mark', what: "3", when: 3}});
chat.put({random4: {who: 'mark', what: "4", when: 4}});
chat.put({random5: {who: 'mark', what: "5", when: 5}});
var seen = {1: false, 2: false, 3: false, 4: false, 5: false}
setTimeout(function(){
chat.map(function(m){ }).once(function(msg, field){
var msg = Gun.obj.copy(msg);
if(msg.what){
expect(msg.what).to.be.ok();
seen[msg.when] = true;
}
if(!Gun.obj.map(seen, function(boo){ if(!boo){ return true } })){
done();
}
});
}, 100);
});
});
});
Reference in New Issue View Git Blame Copy Permalink