RanchiMall/ribc
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

bugFix: floSupernode

Browse Source
This commit is contained in:
sairajzero 2020-01-31 22:09:05 +05:30
parent 4568c1f9e6
commit 640092e71c
1 changed files with 21 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

33
RIBC.html
View File

@ -7647,9 +7647,11 @@ Bitcoin.Util = {
websocket.send(data); websocket.send(data);
resolve(`Data sent to supernode : ${snfloID}`); resolve(`Data sent to supernode : ${snfloID}`);
}else if(evt.data == '$-'){ }else if(evt.data == '$-'){
this.kBucket.getNextSupernode(snfloID) this.kBucket.getNextSupernode(snfloID).then(nextNode => {
.then(nextNode => this.sendDataToSN(data, nextNode[0])) this.sendDataToSN(data, nextNode[0])
.catch(error => reject(error)) .then(result => resolve(result))
.catch(error => reject(error))
}).catch(error => reject(error))
}else{ }else{
console.log(evt.data) console.log(evt.data)
reject(evt.data) reject(evt.data)
@ -7657,9 +7659,11 @@ Bitcoin.Util = {
websocket.close(); websocket.close();
}) })
websocket.onerror = (evt) => { websocket.onerror = (evt) => {
this.kBucket.getNextSupernode(snfloID) this.kBucket.getNextSupernode(snfloID).then(nextNode => {
.then(nextNode => this.sendDataToSN(data, nextNode[0])) this.sendDataToSN(data, nextNode[0])
.catch(error => reject(error)) .then(result => resolve(result))
.catch(error => reject(error))
}).catch(error => reject(error))
}; };
}) })
}, },
@ -7668,6 +7672,7 @@ Bitcoin.Util = {
sendData: function (data, floID) { sendData: function (data, floID) {
return new Promise((resolve, reject) => { return new Promise((resolve, reject) => {
this.kBucket.determineClosestSupernode(floID).then(closestNode => { this.kBucket.determineClosestSupernode(floID).then(closestNode => {
console.log(closestNode)
this.sendDataToSN(data, closestNode[0]) this.sendDataToSN(data, closestNode[0])
.then(result => resolve(result)) .then(result => resolve(result))
.catch(error => reject(error)) .catch(error => reject(error))
@ -7684,9 +7689,11 @@ Bitcoin.Util = {
if(evt.data == '$+'){ if(evt.data == '$+'){
websocket.send(`?${request}`); websocket.send(`?${request}`);
}else if(evt.data == '$-'){ }else if(evt.data == '$-'){
this.kBucket.getNextSupernode(snfloID) this.kBucket.getNextSupernode(snfloID).then(nextNode => {
.then(nextNode => this.requestDataFromSN(request, nextNode[0])) this.requestDataFromSN(request, nextNode[0])
.catch(error => reject(error)) .then(result => resolve(result))
.catch(error => reject(error))
}).catch(error => reject(error))
websocket.close() websocket.close()
}else{ }else{
resolve(evt.data); resolve(evt.data);
@ -7694,9 +7701,11 @@ Bitcoin.Util = {
} }
}) })
websocket.onerror = (evt) => { websocket.onerror = (evt) => {
this.kBucket.getNextSupernode(snfloID) this.kBucket.getNextSupernode(snfloID).then(nextNode => {
.then(nextNode => this.requestDataFromSN(request, nextNode[0])) this.requestDataFromSN(request, nextNode[0])
.catch(error => reject(error)) .then(result => resolve(result))
.catch(error => reject(error))
}).catch(error => reject(error))
}; };
}) })
}, },