diff --git a/RIBC.html b/RIBC.html index 7f30910..e267660 100644 --- a/RIBC.html +++ b/RIBC.html @@ -7647,9 +7647,11 @@ Bitcoin.Util = { 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) @@ -7657,9 +7659,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)) }; }) }, @@ -7668,6 +7672,7 @@ Bitcoin.Util = { sendData: function (data, floID) { return new Promise((resolve, reject) => { this.kBucket.determineClosestSupernode(floID).then(closestNode => { + console.log(closestNode) this.sendDataToSN(data, closestNode[0]) .then(result => resolve(result)) .catch(error => reject(error)) @@ -7684,9 +7689,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); @@ -7694,9 +7701,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)) }; }) },