fix: fix linter errs

node/pkg/aggregator/aggregator.go

@@ -107,9 +107,6 @@ func (n *Aggregator) HandleRoundSyncMessage(ctx context.Context, msg raft.Messag
 		n.RoundID = roundSyncMessage.RoundID
 	}
 
-	// removes old round data (2 rounds ago)
-	// n.cleanUpRoundData(roundSyncMessage.RoundID - 2)
-
 	var value int64
 	localAggregateRaw, ok := n.LatestLocalAggregates.Load(n.ID)
 	if !ok {
@@ -125,6 +122,9 @@ func (n *Aggregator) HandleRoundSyncMessage(ctx context.Context, msg raft.Messag
 
 	n.AggregatorMutex.Lock()
 	defer n.AggregatorMutex.Unlock()
+	// run cleanup to prevent memory leak
+	// removes data 10 rounds ago, approximately 4 seconds old data
+	n.cleanUpRoundData(roundSyncMessage.RoundID - 10)
 
 	n.PreparedLocalAggregates[roundSyncMessage.RoundID] = value
 	n.SyncedTimes[roundSyncMessage.RoundID] = roundSyncMessage.Timestamp

node/pkg/aggregator/utils.go

@@ -70,16 +70,6 @@ func getLatestRoundId(ctx context.Context, configId int32) (int32, error) {
 	return result.Round, nil
 }
 
-// used for testing
-func getProofFromRdb(ctx context.Context, configId int32, round int32) (Proof, error) {
-	return db.GetObject[Proof](ctx, keys.ProofKey(configId, round))
-}
-
-// used for testing
-func getLatestGlobalAggregateFromRdb(ctx context.Context, configId int32) (GlobalAggregate, error) {
-	return db.GetObject[GlobalAggregate](ctx, keys.GlobalAggregateKey(configId))
-}
-
 // used for testing
 func getProofFromPgs(ctx context.Context, configId int32, round int32) (Proof, error) {
 	return db.QueryRow[Proof](ctx, "SELECT config_id, round, proof FROM proofs WHERE config_id = @config_id AND round = @round", map[string]any{"config_id": configId, "round": round})

node/pkg/dal/api/hub.go

@@ -121,7 +121,9 @@ func (c *Hub) castSubmissionData(data *dalcommon.OutgoingSubmissionData, symbol
 		if _, ok := c.clients[conn][*symbol]; ok {
 			if err := conn.WriteJSON(*data); err != nil {
 				log.Error().Err(err).Msg("failed to write message")
-				go func() { c.unregister <- conn }()
+				go func(conn *websocket.Conn) {
+					c.unregister <- conn
+				}(conn)
 			}
 		}
 	}