From 65b23c4ff7ba3e13df7b8d9108f99fa22982bf28 Mon Sep 17 00:00:00 2001
From: Cassandra Heart <cassandra@quilibrium.com>
Date: Fri, 14 Mar 2025 12:05:30 -0500
Subject: [PATCH] minor tweaks

---
 node/rpc/hypergraph_sync_rpc_server.go | 38 --------------------------
 1 file changed, 38 deletions(-)

diff --git a/node/rpc/hypergraph_sync_rpc_server.go b/node/rpc/hypergraph_sync_rpc_server.go
index b9b9cee..f079e74 100644
--- a/node/rpc/hypergraph_sync_rpc_server.go
+++ b/node/rpc/hypergraph_sync_rpc_server.go
@@ -310,7 +310,6 @@ type streamManager struct {
 	stream          HyperStream
 	hypergraphStore store.HypergraphStore
 	localTree       *crypto.VectorCommitmentTree
-	leavesSent      int
 	lastSent        time.Time
 }
 
@@ -378,10 +377,6 @@ func (s *streamManager) sendLeafData(
 			if child == nil {
 				continue
 			}
-			s.leavesSent++
-			if s.leavesSent > 100000 {
-				return nil
-			}
 
 			if err := send(child); err != nil {
 				return err
@@ -668,10 +663,6 @@ func (s *streamManager) walk(
 	incomingResponses <-chan *protobufs.HypergraphComparisonResponse,
 	metadataOnly bool,
 ) error {
-	if s.leavesSent > 100000 {
-		return nil
-	}
-
 	select {
 	case <-s.ctx.Done():
 		return s.ctx.Err()
@@ -1068,7 +1059,6 @@ func syncTreeBidirectionallyServer(
 	}()
 
 	lastReceived := time.Now()
-	leavesReceived := 0
 
 outer:
 	for {
@@ -1077,10 +1067,6 @@ outer:
 			if !ok {
 				break outer
 			}
-			leavesReceived++
-			if leavesReceived > 100000 {
-				break outer
-			}
 
 			logger.Info(
 				"received leaf data",
@@ -1089,15 +1075,6 @@ outer:
 
 			theirs := hypergraph.AtomFromBytes(remoteUpdate.Value)
 
-			ours, _ := idSet.GetTree().Get(remoteUpdate.Key)
-			if ours != nil {
-				ourCommit := hypergraph.AtomFromBytes(ours).Commit()
-				theirCommit := theirs.Commit()
-				if bytes.Compare(ourCommit, theirCommit) < 0 {
-					continue
-				}
-			}
-
 			if len(remoteUpdate.UnderlyingData) != 0 {
 				txn, err := localHypergraphStore.NewTransaction(false)
 				if err != nil {
@@ -1346,7 +1323,6 @@ func SyncTreeBidirectionally(
 	}()
 
 	lastReceived := time.Now()
-	leavesReceived := 0
 
 outer:
 	for {
@@ -1356,11 +1332,6 @@ outer:
 				break outer
 			}
 
-			leavesReceived++
-			if leavesReceived > 100000 {
-				break outer
-			}
-
 			logger.Info(
 				"received leaf data",
 				zap.String("key", hex.EncodeToString(remoteUpdate.Key)),
@@ -1368,15 +1339,6 @@ outer:
 
 			theirs := hypergraph.AtomFromBytes(remoteUpdate.Value)
 
-			ours, _ := set.GetTree().Get(remoteUpdate.Key)
-			if ours != nil {
-				ourCommit := hypergraph.AtomFromBytes(ours).Commit()
-				theirCommit := theirs.Commit()
-				if bytes.Compare(ourCommit, theirCommit) < 0 {
-					continue
-				}
-			}
-
 			if len(remoteUpdate.UnderlyingData) != 0 {
 				txn, err := hypergraphStore.NewTransaction(false)
 				if err != nil {