orbitdb/orbit-db
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Testing

Browse Source
This commit is contained in:
haad 2016-02-10 17:58:01 +01:00
parent a419b0d527
commit 1a99681a5b
1 changed files with 15 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
src/PubSub.js
View File

@ -36,10 +36,17 @@ class PubSub {
publish(hash, message, seq, callback) { publish(hash, message, seq, callback) {
return new Promise((resolve, reject) => { return new Promise((resolve, reject) => {
if(this.publishQueue.length === 0) if(this.publishQueue.length === 0) {
this.publishQueue.splice(0, 0, { hash: message.Hash, callback: resolve }); this.publishQueue.splice(0, 0, { hash: message.Hash, callback: resolve });
this.client2.publish(hash, JSON.stringify({ hash: message.Hash, seq: seq })); this.client2.publish(hash, JSON.stringify({ hash: message.Hash, seq: seq }));
setTimeout(() => resolve(false), 1000) } else {
console.log("too early")
// resolve(false);
}
setTimeout(() => {
this.publishQueue.pop();
resolve(false);
}, 2000)
}); });
} }
@ -59,14 +66,14 @@ class PubSub {
var isNewer = seq > this._subscriptions[hash].seq; var isNewer = seq > this._subscriptions[hash].seq;
var item = this.publishQueue[this.publishQueue.length - 1]; var item = this.publishQueue[this.publishQueue.length - 1];
// console.log(".", isNewer, newHead, item ? item.hash : '', seq, this._subscriptions[hash].seq, message) // console.log(".", isNewer, newHead, item ? item.hash : '', seq, this._subscriptions[hash].seq)
if(item) {
item.callback(isNewer && newHead === item.hash);
this.publishQueue.pop();
}
// console.log(isNewer, seq, this._subscriptions[hash].seq) // console.log(isNewer, seq, this._subscriptions[hash].seq)
if(item) {
this.publishQueue.pop();
item.callback(isNewer && newHead === item.hash);
}
if(isNewer) if(isNewer)
this._updateSubscription(hash, newHead, seq); this._updateSubscription(hash, newHead, seq);
} }