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

bug fix: floSupernode module

Browse Source
This commit is contained in:
sairajzero 2020-01-31 20:22:35 +05:30
parent a44fe4be72
commit 2bf166ffd1
1 changed files with 20 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

33
standard_Operations.html
View File

@ -7638,16 +7638,17 @@ Bitcoin.Util = {
sendDataToSN(data, snfloID){
return new Promise((resolve, reject) => {
console.log(snfloID)
var websocket = new WebSocket("wss://" + floGlobals.supernodes[snfloID].uri + "/ws");
websocket.onmessage = (evt => {
if(evt.data == '$+'){
websocket.send(data);
resolve(`Data sent to supernode : ${snfloID}`);
}else if(evt.data == '$-'){
this.kBucket.getNextSupernode(snfloID)
.then(nextNode => this.sendDataToSN(data, nextNode[0]))
.catch(error => reject(error))
this.kBucket.getNextSupernode(snfloID).then(nextNode => {
this.sendDataToSN(data, nextNode[0])
.then(result => resolve(result))
.catch(error => reject(error))
}).catch(error => reject(error))
}else{
console.log(evt.data)
reject(evt.data)
@ -7655,9 +7656,11 @@ Bitcoin.Util = {
websocket.close();
})
websocket.onerror = (evt) => {
this.kBucket.getNextSupernode(snfloID)
.then(nextNode => this.sendDataToSN(data, nextNode[0]))
.catch(error => reject(error))
this.kBucket.getNextSupernode(snfloID).then(nextNode => {
this.sendDataToSN(data, nextNode[0])
.then(result => resolve(result))
.catch(error => reject(error))
}).catch(error => reject(error))
};
})
},
@ -7682,9 +7685,11 @@ Bitcoin.Util = {
if(evt.data == '$+'){
websocket.send(`?${request}`);
}else if(evt.data == '$-'){
this.kBucket.getNextSupernode(snfloID)
.then(nextNode => this.requestDataFromSN(request, nextNode[0]))
.catch(error => reject(error))
this.kBucket.getNextSupernode(snfloID).then(nextNode => {
this.requestDataFromSN(request, nextNode[0])
.then(result => resolve(result))
.catch(error => reject(error))
}).catch(error => reject(error))
websocket.close()
}else{
resolve(evt.data);
@ -7692,9 +7697,11 @@ Bitcoin.Util = {
}
})
websocket.onerror = (evt) => {
this.kBucket.getNextSupernode(snfloID)
.then(nextNode => this.requestDataFromSN(request, nextNode[0]))
.catch(error => reject(error))
this.kBucket.getNextSupernode(snfloID).then(nextNode => {
this.requestDataFromSN(request, nextNode[0])
.then(result => resolve(result))
.catch(error => reject(error))
}).catch(error => reject(error))
};
})
},