debug.js
1.88 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
;(function(){
if('debug' !== process.env.GUN_ENV){ return }
var db = {length: 0, hash: {}};
console.log("start :)");
global.DEBUG = 1;
setInterval(function(){
var print = '', tmp;
var mem = process.memoryUsage();
var used = mem.rss / 1024 / 1024;
used = used.toFixed(1);
print += used +' MB rss. ';
var used = mem.heapTotal / 1024 / 1024;
used = used.toFixed(1);
print += used +' MB hT. ';
var used = mem.heapUsed / 1024 / 1024;
used = used.toFixed(1);
print += used +' MB hU. ';
if(db.root){
db.concurrency = Object.keys(db.peers||{}).length;
print += db.concurrency +' peers. ';
db.nodes = Object.keys(db.root.graph||{}).length;
print += db.nodes + ' nodes. ';
if(db.count){ print += db.count + ' msgs. '}
if(tmp = db.root.msgsLength){
tmp = (tmp / 1024 / 1024).toFixed(2);
print += tmp + ' length MB. ';
}
if(db.last){ print += '\n' + JSON.stringify(db.last, null, 2) }
if(db.hash){
print += '\nSome 100 Fast Hash Counts: \n' + JSON.stringify(db.hash, null, 2);
var l = Object.keys(db.hash), i = l.length;
if(i > 100){
i = i - 100;
Gun.list.map(l, function(k){
if(--i <= 0){ return }
delete db.hash[k];
});
}
}
}
db.print = print;
print = print.split('\n')[0];
console.log(print);
}, 2500);
var Gun = require('../gun');
Gun.on('opt', function(root){
this.to.next(root);
if(root.once){ return }
console.log(">>>>>>>>>", root);
root.debug = db;
db.root = root;
db.peers = root.opt.peers;
db.count = 0;
root.on('in', function(msg){
this.to.next(msg);
if(!msg.NTS){ db.last = msg }
db.count++;
var tmp = msg['##'];
if(tmp && msg.put){
if(!db.hash[tmp]){ db.hash[tmp] = [0, ''] }
db.hash[tmp][0] = (db.hash[tmp][0] || 0) + 1;
var preview = Object.keys(msg.put||{});
db.hash[tmp][1] = preview.toString(', ').slice(0,500) + ' ...';
}
});
})
}());