From 19380dbd9f18ee092ddedb627d8313c45eb58831 Mon Sep 17 00:00:00 2001
From: Alexey Kasyanchuk <degitx@gmail.com>
Date: Mon, 18 Jun 2018 14:55:40 +0300
Subject: [PATCH] feat(store): live sync store records on connection to every
 peer

---
 src/background/store.js | 28 +++++++++++++++++++---------
 1 file changed, 19 insertions(+), 9 deletions(-)

diff --git a/src/background/store.js b/src/background/store.js
index 1753fda..b972744 100644
--- a/src/background/store.js
+++ b/src/background/store.js
@@ -7,6 +7,10 @@ module.exports = class P2PStore extends EventEmitter {
 	{
 		super()
 		this.id = 0
+		Object.defineProperty(p2p.info, 'store', { 
+			enumerable: true,
+			get: () => this.id
+		});
 		this.synchronized = false
 
 		console.log('connect p2p store...')
@@ -22,12 +26,14 @@ module.exports = class P2PStore extends EventEmitter {
                 
 			console.log('store db index', this.id)
 
-			let lock = false
-			this.p2p.events.on('peer', () => {
-				if(lock)
-					return
-				lock = true
-				setTimeout(() => this.sync(), 1000)
+			this.p2p.events.on('peer', (peer) => {
+				if(peer.info && peer.info.store)
+				{
+					if(peer.info.store > this.id)
+						this.sync(peer) // sync db
+					else if(peer.info.store === this.id)
+						this.synchronized = true
+				}
 			})
 		})
 
@@ -69,9 +75,9 @@ module.exports = class P2PStore extends EventEmitter {
 		})
 	}
 
-	sync()
+	sync(peer)
 	{
-		console.log('sync db on version', this.id)
+		console.log('sync db on version', this.id, peer ? `from peer ${peer.peerId}` : '')
 		const processSync = (data, nil, peer) => {
 			if(!data || !data.records)
 				return
@@ -88,7 +94,11 @@ module.exports = class P2PStore extends EventEmitter {
 				peer.emit('dbSync', {id: this.id}, processSync)
 			}
 		}
-		this.p2p.emit('dbSync', {id: this.id}, processSync)
+		if(peer)
+			peer.emit('dbSync', {id: this.id}, processSync)
+		else
+			this.p2p.emit('dbSync', {id: this.id}, processSync)
+
 		this.synchronized = true
 	}