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

easy to debug & fix thanks to @rogowski 's test upgrades & trace!

Browse Source
This commit is contained in:
Mark Nadal 2021-01-22 05:10:21 -08:00
parent 1001d5a26b
commit ea587964c3
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
gun.js
View File

@ -734,7 +734,7 @@
function ack(msg, ev){ function ack(msg, ev){
// manhattan: // manhattan:
var as = this.as, at = as.$._, get = as.get||'', tmp = (msg.put||'')[get['#']]||''; var as = this.as, at = as.$._, get = as.get||'', tmp = (msg.put||'')[get['#']]||'';
if(!msg.put || ('string' == typeof get['.'] && u === tmp[at.get])){ if(!msg.put || ('string' == typeof get['.'] && u === tmp[get['.']])){
if(u !== at.put){ return } if(u !== at.put){ return }
at.on('in', { at.on('in', {
get: at.get, get: at.get,
@ -922,7 +922,7 @@
var id = as.seen.length; var id = as.seen.length;
(as.wait || (as.wait = {}))[id] = ''; (as.wait || (as.wait = {}))[id] = '';
tmp = (cat.ref = (g? d : k? at.ref.get(k) : at.ref))._; tmp = (cat.ref = (g? d : k? at.ref.get(k) : at.ref))._;
(tmp = tmp.soul || tmp.link || tmp.dub)? resolve({soul: tmp}) : cat.ref.get(resolve, {stun: 0, v2020:1}); (tmp = (d && (d._||'')['#']) || tmp.soul || tmp.link || tmp.dub)? resolve({soul: tmp}) : cat.ref.get(resolve, {stun: 0, v2020:1});
function resolve(msg, eve){ function resolve(msg, eve){
if(eve){ eve.off(); eve.rid(msg) } // TODO: Too early! Check all peers ack not found. if(eve){ eve.off(); eve.rid(msg) } // TODO: Too early! Check all peers ack not found.
var soul = msg.soul || ((tmp = msg.put) && (tmp = tmp._) && (tmp = tmp['#'])) || ((tmp = msg.put) && (tmp = tmp['='] || tmp[':']) && tmp['#']) || ((tmp = msg.put) && tmp['#']); var soul = msg.soul || ((tmp = msg.put) && (tmp = tmp._) && (tmp = tmp['#'])) || ((tmp = msg.put) && (tmp = tmp['='] || tmp[':']) && tmp['#']) || ((tmp = msg.put) && tmp['#']);