Merge master supernova june2026

cmd/node/config/config.toml

@@ -176,6 +176,7 @@
         BatchDelaySeconds = 2
         MaxBatchSize = 100
         MaxOpenFiles = 10
+        BloomFilterBitsPerKey = 10
 
 [ReceiptsStorage]
     [ReceiptsStorage.Cache]
@@ -189,6 +190,7 @@
         BatchDelaySeconds = 2
         MaxBatchSize = 100
         MaxOpenFiles = 10
+        BloomFilterBitsPerKey = 10
 
 [ScheduledSCRsStorage]
     [ScheduledSCRsStorage.Cache]
@@ -202,6 +204,7 @@
         BatchDelaySeconds = 2
         MaxBatchSize = 100
         MaxOpenFiles = 10
+        BloomFilterBitsPerKey = 10
 
 [PeerBlockBodyStorage]
     [PeerBlockBodyStorage.Cache]
@@ -215,6 +218,7 @@
         BatchDelaySeconds = 2
         MaxBatchSize = 100
         MaxOpenFiles = 10
+        BloomFilterBitsPerKey = 10
 
 [BlockHeaderStorage]
     [BlockHeaderStorage.Cache]
@@ -228,6 +232,7 @@
         BatchDelaySeconds = 2
         MaxBatchSize = 100
         MaxOpenFiles = 10
+        BloomFilterBitsPerKey = 10
         ShardIDProviderType = "BinarySplit"
         NumShards = 4
 
@@ -243,6 +248,7 @@
         BatchDelaySeconds = 2
         MaxBatchSize = 100
         MaxOpenFiles = 10
+        BloomFilterBitsPerKey = 10
 
 [MetaBlockStorage]
     [MetaBlockStorage.Cache]
@@ -256,6 +262,7 @@
         BatchDelaySeconds = 2
         MaxBatchSize = 100
         MaxOpenFiles = 10
+        BloomFilterBitsPerKey = 10
         ShardIDProviderType = "BinarySplit"
         NumShards = 4
 
@@ -271,6 +278,7 @@
         BatchDelaySeconds = 2
         MaxBatchSize = 100
         MaxOpenFiles = 10
+        BloomFilterBitsPerKey = 10
 
 [ExecutionResultsStorage]
     [ExecutionResultsStorage.Cache]
@@ -297,6 +305,7 @@
         BatchDelaySeconds = 2
         MaxBatchSize = 30000
         MaxOpenFiles = 10
+        BloomFilterBitsPerKey = 10
         ShardIDProviderType = "BinarySplit"
         NumShards = 4
 
@@ -312,6 +321,7 @@
         BatchDelaySeconds = 2
         MaxBatchSize = 20000
         MaxOpenFiles = 10
+        BloomFilterBitsPerKey = 10
 
 [RewardTxStorage]
     [RewardTxStorage.Cache]
@@ -325,6 +335,7 @@
         BatchDelaySeconds = 2
         MaxBatchSize = 20000
         MaxOpenFiles = 10
+        BloomFilterBitsPerKey = 10
 
 [SmartContractsStorage]
     [SmartContractsStorage.Cache]
@@ -338,6 +349,7 @@
         BatchDelaySeconds = 2
         MaxBatchSize = 100
         MaxOpenFiles = 10
+        BloomFilterBitsPerKey = 10
 
 [SmartContractsStorageSimulate]
     [SmartContractsStorageSimulate.Cache]
@@ -351,6 +363,7 @@
         BatchDelaySeconds = 2
         MaxBatchSize = 100
         MaxOpenFiles = 10
+        BloomFilterBitsPerKey = 10
 
 [SmartContractsStorageForSCQuery]
     [SmartContractsStorageForSCQuery.Cache]
@@ -364,6 +377,7 @@
         BatchDelaySeconds = 2
         MaxBatchSize = 100
         MaxOpenFiles = 10
+        BloomFilterBitsPerKey = 10
 
 [StatusMetricsStorage]
     [StatusMetricsStorage.Cache]
@@ -376,6 +390,7 @@
         BatchDelaySeconds = 2
         MaxBatchSize = 100
         MaxOpenFiles = 10
+        BloomFilterBitsPerKey = 10
 
 [TrieEpochRootHashStorage]
     [TrieEpochRootHashStorage.Cache]
@@ -389,6 +404,7 @@
         BatchDelaySeconds = 2
         MaxBatchSize = 500
         MaxOpenFiles = 10
+        BloomFilterBitsPerKey = 10
 
 [ShardHdrNonceHashStorage]
     [ShardHdrNonceHashStorage.Cache]
@@ -402,6 +418,7 @@
         BatchDelaySeconds = 2
         MaxBatchSize = 100
         MaxOpenFiles = 10
+        BloomFilterBitsPerKey = 10
 
 [MetaHdrNonceHashStorage]
     [MetaHdrNonceHashStorage.Cache]
@@ -415,6 +432,7 @@
         BatchDelaySeconds = 2
         MaxBatchSize = 100
         MaxOpenFiles = 10
+        BloomFilterBitsPerKey = 10
 
 [AccountsTrieStorage]
     [AccountsTrieStorage.Cache]
@@ -443,6 +461,7 @@
         BatchDelaySeconds = 2
         MaxBatchSize = 100
         MaxOpenFiles = 10
+        BloomFilterBitsPerKey = 10
 
 [PeerAccountsTrieStorage]
     [PeerAccountsTrieStorage.Cache]
@@ -469,6 +488,7 @@
         BatchDelaySeconds = 2
         MaxBatchSize = 100
         MaxOpenFiles = 10
+        BloomFilterBitsPerKey = 10
 
 [TrieStorageManagerConfig]
     PruningBufferLen = 100000
@@ -636,16 +656,18 @@
         MaxBatchSize = 45000
         MaxOpenFiles = 10
         UseTmpAsFilePath = true
+        BloomFilterBitsPerKey = 10
 
 [Antiflood]
     Enabled = true
+    MaxAllowedTrieNodeChunks = 10
+    TrieNodeChunksInactivityTimeoutInSec = 10
 
     [[Antiflood.ConfigsByRound]]
         Round = 0
         NumConcurrentResolverJobs = 50
         NumConcurrentResolvingTrieNodesJobs = 3
-
-        [Antiflood.ConfigsByRound.FastReacting]
+    [Antiflood.ConfigsByRound.FastReacting]
             IntervalInSeconds = 1
             ReservedPercent   = 20.0
             [Antiflood.ConfigsByRound.FastReacting.PeerMaxInput]
@@ -967,6 +989,7 @@
             BatchDelaySeconds = 2
             MaxBatchSize = 1000
             MaxOpenFiles = 10
+            BloomFilterBitsPerKey = 10
     [Hardfork.ExportKeysStorageConfig]
         [Hardfork.ExportKeysStorageConfig.Cache]
             Name = "HardFork.ExportKeysStorageConfig"
@@ -978,6 +1001,7 @@
             BatchDelaySeconds = 2
             MaxBatchSize = 1000
             MaxOpenFiles = 10
+            BloomFilterBitsPerKey = 10
     [Hardfork.ExportTriesStorageConfig]
         [Hardfork.ExportTriesStorageConfig.Cache]
             Name = "HardFork.ExportTriesStorageConfig"
@@ -989,6 +1013,7 @@
             BatchDelaySeconds = 2
             MaxBatchSize = 1000
             MaxOpenFiles = 10
+            BloomFilterBitsPerKey = 10
     [Hardfork.ImportStateStorageConfig]
         [Hardfork.ImportStateStorageConfig.Cache]
             Name = "HardFork.ImportStateStorageConfig"
@@ -1000,6 +1025,7 @@
             BatchDelaySeconds = 2
             MaxBatchSize = 1000
             MaxOpenFiles = 10
+            BloomFilterBitsPerKey = 10
     [Hardfork.ImportKeysStorageConfig]
         [Hardfork.ImportKeysStorageConfig.Cache]
             Name = "HardFork.ImportKeysStorageConfig"
@@ -1011,6 +1037,7 @@
             BatchDelaySeconds = 2
             MaxBatchSize = 1000
             MaxOpenFiles = 10
+            BloomFilterBitsPerKey = 10
 
 [Debug]
     [Debug.InterceptorResolver]
@@ -1073,6 +1100,7 @@
         BatchDelaySeconds = 2
         MaxBatchSize = 100
         MaxOpenFiles = 10
+        BloomFilterBitsPerKey = 10
 
 [DbLookupExtensions]
     Enabled = false
@@ -1087,6 +1115,7 @@
         BatchDelaySeconds = 2
         MaxBatchSize = 20000
         MaxOpenFiles = 10
+        BloomFilterBitsPerKey = 10
     [DbLookupExtensions.MiniblockHashByTxHashStorageConfig.Cache]
         Name = "DbLookupExtensions.MiniblockHashByTxHashStorage"
         Capacity = 20000
@@ -1097,6 +1126,7 @@
         BatchDelaySeconds = 2
         MaxBatchSize = 20000
         MaxOpenFiles = 10
+        BloomFilterBitsPerKey = 10
         ShardIDProviderType = "BinarySplit"
         NumShards = 4
     [DbLookupExtensions.EpochByHashStorageConfig.Cache]
@@ -1109,6 +1139,7 @@
         BatchDelaySeconds = 2
         MaxBatchSize = 20000
         MaxOpenFiles = 10
+        BloomFilterBitsPerKey = 10
         ShardIDProviderType = "BinarySplit"
         NumShards = 4
     [DbLookupExtensions.ResultsHashesByTxHashStorageConfig.Cache]
@@ -1121,6 +1152,7 @@
         BatchDelaySeconds = 2
         MaxBatchSize = 20000
         MaxOpenFiles = 10
+        BloomFilterBitsPerKey = 10
     [DbLookupExtensions.ESDTSuppliesStorageConfig.Cache]
         Name = "DbLookupExtensions.ESDTSuppliesStorage"
         Capacity = 20000
@@ -1131,6 +1163,7 @@
         BatchDelaySeconds = 2
         MaxBatchSize = 20000
         MaxOpenFiles = 10
+        BloomFilterBitsPerKey = 10
     [DbLookupExtensions.RoundHashStorageConfig.Cache]
         Name = "DbLookupExtensions.RoundHashStorage"
         Capacity = 20000
@@ -1141,6 +1174,7 @@
         BatchDelaySeconds = 2
         MaxBatchSize = 20000
         MaxOpenFiles = 10
+        BloomFilterBitsPerKey = 10
 
 [Logs]
     LogFileLifeSpanInMB = 1024 # 1GB

common/chainparametersnotifier/chainParametersNotifier_test.go

@@ -5,8 +5,9 @@ import (
 	"testing"
 
 	"github.com/multiversx/mx-chain-core-go/core/check"
-	"github.com/multiversx/mx-chain-go/config"
 	"github.com/stretchr/testify/require"
+
+	"github.com/multiversx/mx-chain-go/config"
 )
 
 func TestNewChainParametersNotifier(t *testing.T) {
@@ -112,12 +113,15 @@ func TestChainParametersNotifier_ConcurrentOperations(t *testing.T) {
 }
 
 type dummyNotifee struct {
-	receivedChainParameters config.ChainParametersByEpochConfig
+	receivedChainParameters    config.ChainParametersByEpochConfig
+	mutReceivedChainParameters sync.RWMutex
 }
 
 // ChainParametersChanged -
 func (dn *dummyNotifee) ChainParametersChanged(chainParameters config.ChainParametersByEpochConfig) {
+	dn.mutReceivedChainParameters.Lock()
 	dn.receivedChainParameters = chainParameters
+	dn.mutReceivedChainParameters.Unlock()
 }
 
 // IsInterfaceNil -

common/common.go

@@ -14,10 +14,10 @@ import (
 	"github.com/multiversx/mx-chain-core-go/core/check"
 	"github.com/multiversx/mx-chain-core-go/data"
 	"github.com/multiversx/mx-chain-core-go/data/block"
-	"github.com/multiversx/mx-chain-go/errors"
 	logger "github.com/multiversx/mx-chain-logger-go"
 
 	"github.com/multiversx/mx-chain-go/config"
+	"github.com/multiversx/mx-chain-go/errors"
 )
 
 const (
@@ -153,6 +153,14 @@ func IsConsensusBitmapValid(
 		return ErrWrongSizeBitmap
 	}
 
+	paddingBits := consensusSize % 8
+	if paddingBits != 0 {
+		paddingMask := byte(0xFF << paddingBits)
+		if bitmap[len(bitmap)-1]&paddingMask != 0 {
+			return ErrPaddingBitsSet
+		}
+	}
+
 	numOfOnesInBitmap := 0
 	for index := range bitmap {
 		numOfOnesInBitmap += bits.OnesCount8(bitmap[index])

common/common_test.go

@@ -109,6 +109,29 @@ func TestIsConsensusBitmapValid(t *testing.T) {
 		require.Equal(t, common.ErrNotEnoughSignatures, err)
 	})
 
+	t.Run("padding bits set should return error", func(t *testing.T) {
+		t.Parallel()
+
+		// consensus size is 10, so bitmap should have 2 bytes
+		bitmap := make([]byte, len(pubKeys)/8+1)
+		bitmap[0] = 0xFF
+		bitmap[1] = 0x07
+
+		err := common.IsConsensusBitmapValid(log, pubKeys, bitmap, false)
+		require.Equal(t, common.ErrPaddingBitsSet, err)
+	})
+
+	t.Run("padding bits not set should return nil", func(t *testing.T) {
+		t.Parallel()
+
+		bitmap := make([]byte, len(pubKeys)/8+1)
+		bitmap[0] = 0xFF
+		bitmap[1] = 0x03
+
+		err := common.IsConsensusBitmapValid(log, pubKeys, bitmap, false)
+		require.Nil(t, err)
+	})
+
 	t.Run("should work", func(t *testing.T) {
 		t.Parallel()
 

common/errors.go

@@ -41,6 +41,9 @@ var ErrInvalidHashShardKey = errors.New("invalid hash shard key")
 // ErrInvalidNonceShardKey signals that the provided nonce-shard key is invalid
 var ErrInvalidNonceShardKey = errors.New("invalid nonce shard key")
 
+// ErrPaddingBitsSet signals that the provided bitmap has padding bits set to 1 instead of 0
+var ErrPaddingBitsSet = errors.New("padding bits in the bitmap should be zero")
+
 // ErrNilCommonConfigsHandler signals that a nil common configs handler has been provided
 var ErrNilCommonConfigsHandler = errors.New("nil common configs handler")
 

common/peerAuthentication.go

@@ -0,0 +1,14 @@
+package common
+
+// MaxPeerAuthenticationPublicKeyIdentifierLen is the maximum number of public key bytes used as
+// a peer authentication request/whitelist identifier.
+const MaxPeerAuthenticationPublicKeyIdentifierLen = 32
+
+// PeerAuthenticationPublicKeyIdentifier returns the public key prefix used as request/whitelist identifier.
+func PeerAuthenticationPublicKeyIdentifier(publicKey []byte) []byte {
+	if len(publicKey) > MaxPeerAuthenticationPublicKeyIdentifierLen {
+		publicKey = publicKey[:MaxPeerAuthenticationPublicKeyIdentifierLen]
+	}
+
+	return append([]byte(nil), publicKey...)
+}