evan/rats-search
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix(store): store on all peers

Browse Source
This commit is contained in:
Alexey Kasyanchuk
2018-04-20 19:28:59 +03:00
parent 959344080e
commit 5773fa7408
1 changed files with 9 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
src/background/store.js
View File

@ -36,7 +36,10 @@ module.exports = class P2PStore extends EventEmitter {
return return
} }
this._syncRecord(record) this._syncRecord(record, () => {
// redirect other peers that record are stored
this.p2p.emit('dbStore', record)
})
}) })
this.p2p.on('dbSync', ({id} = {}, callback) => { this.p2p.on('dbSync', ({id} = {}, callback) => {
@ -72,7 +75,7 @@ module.exports = class P2PStore extends EventEmitter {
}) })
} }
_syncRecord(record) _syncRecord(record, callback)
{ {
if(!record) if(!record)
return return
@ -100,6 +103,10 @@ module.exports = class P2PStore extends EventEmitter {
console.log('sync peerdb record', record.id) console.log('sync peerdb record', record.id)
this._pushToDb(record) this._pushToDb(record)
this.id = record.id this.id = record.id
// redirect to next
if(callback)
callback()
} }
_pushToDb(value, callback) _pushToDb(value, callback)