fix consensus to allow one consensus block per peer per index

pdxwebdev · Dec 15, 2020 · 692223b · 692223b
1 parent dfda96f
commit 692223b
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 5 deletions.
diff --git a/yadacoin/core/consensus.py b/yadacoin/core/consensus.py
@@ -95,16 +95,16 @@ async def insert_consensus_block(self, block, peer):
             block.verify()
         except:
             return
-        await self.mongo.async_db.consensus.replace_one({
-            'id': block.signature,
+        await self.mongo.async_db.consensus.delete_many({
+            'index': block.index,
             'peer.rid': peer.rid
-        },
-        {
+        })
+        await self.mongo.async_db.consensus.update_one({
             'block': block.to_dict(),
             'index': block.index,
             'id': block.signature,
             'peer': peer.to_dict()
-        }, upsert=True)
+        })
 
     async def sync_bottom_up(self):
         #bottom up syncing

diff --git a/yadacoin/tcpsocket/node.py b/yadacoin/tcpsocket/node.py
@@ -332,6 +332,7 @@ async def authenticate(self, body, stream):
         if result:
             stream.peer.authenticated = True
             self.config.app_log.info('Authenticated {}: {}'.format(stream.peer.__class__.__name__, stream.peer.to_json()))
+            await self.send_block(self.config.LatestBlock.block)
         else:
             stream.close()