From 5773fa7408c304eba1c2eed3510f302cf456a5be Mon Sep 17 00:00:00 2001 From: Alexey Kasyanchuk Date: Fri, 20 Apr 2018 19:28:59 +0300 Subject: [PATCH] fix(store): store on all peers --- src/background/store.js | 11 +++++++++-- 1 file changed, 9 insertions(+), 2 deletions(-) diff --git a/src/background/store.js b/src/background/store.js index 312cc45..22374d9 100644 --- a/src/background/store.js +++ b/src/background/store.js @@ -36,7 +36,10 @@ module.exports = class P2PStore extends EventEmitter { 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) => { @@ -72,7 +75,7 @@ module.exports = class P2PStore extends EventEmitter { }) } - _syncRecord(record) + _syncRecord(record, callback) { if(!record) return @@ -100,6 +103,10 @@ module.exports = class P2PStore extends EventEmitter { console.log('sync peerdb record', record.id) this._pushToDb(record) this.id = record.id + + // redirect to next + if(callback) + callback() } _pushToDb(value, callback)