[DO NOT MERGE] SF 2.0

cmd/node/main.go

@@ -3,6 +3,7 @@ package main
 import (
 	"fmt"
 	"os"
+	"path/filepath"
 	"runtime"
 	"time"
 
@@ -82,13 +83,43 @@ func main() {
 		return startNodeRunner(c, log, baseVersion, app.Version)
 	}
 
+	// TODO: remove this after the first release
+	renameDB()
+
 	err := app.Run(os.Args)
 	if err != nil {
 		log.Error(err.Error())
 		os.Exit(1)
 	}
 }
 
+func renameDB() {
+	// Define source and destination paths
+	sourcePath := filepath.Join("db", "1")
+	destPath := filepath.Join("db", "B")
+
+	// Check if source directory exists
+	if _, err := os.Stat(sourcePath); os.IsNotExist(err) {
+		fmt.Printf("Error: Source directory '%s' does not exist\n", sourcePath)
+		os.Exit(1)
+	}
+
+	// Check if destination already exists
+	if _, err := os.Stat(destPath); err == nil {
+		fmt.Printf("Error: Destination directory '%s' already exists\n", destPath)
+		os.Exit(1)
+	}
+
+	// Rename the directory
+	err := os.Rename(sourcePath, destPath)
+	if err != nil {
+		fmt.Printf("Error renaming directory: %v\n", err)
+		os.Exit(1)
+	}
+
+	fmt.Printf("Successfully renamed '%s' to '%s'\n", sourcePath, destPath)
+}
+
 func startNodeRunner(c *cli.Context, log logger.Logger, baseVersion string, version string) error {
 	flagsConfig := getFlagsConfig(c, log)
 

common/common.go

@@ -635,3 +635,47 @@ func GetDeveloperFeesInEpoch(header data.HeaderHandler) *big.Int {
 
 	return metaExecutionResult.GetExecutionResultHandler().GetDevFeesInEpoch()
 }
+
+type EnableEpochsHandlerWithSet interface {
+	SetActivationRound(flag EnableRoundFlag, round uint64)
+}
+
+type ProcessConfigsHandlerWithSet interface {
+	SetActivationRound(round uint64, log logger.Logger)
+}
+
+type CommonConfigsHandlerWithSet interface {
+	SetActivationRound(round uint64, log logger.Logger)
+}
+
+var erh EnableEpochsHandlerWithSet
+var eeh EnableEpochsHandler
+var pch ProcessConfigsHandlerWithSet
+var cch CommonConfigsHandlerWithSet
+
+func SetEnableRoundsHandler(enableRoundsHandler EnableEpochsHandlerWithSet) {
+	erh = enableRoundsHandler
+}
+
+func SetProcessConfigsHandler(pcHandler ProcessConfigsHandler) {
+	pch = pcHandler
+}
+
+func SetCommonConfigsHandler(ccHandler CommonConfigsHandler) {
+	cch = ccHandler
+}
+
+func SetEnableEpochsHandler(enableEpochsHandler EnableEpochsHandler) {
+	eeh = enableEpochsHandler
+}
+
+func SetSuperNovaActivationRound(epoch uint32, round uint64) {
+	isEnabled := eeh.GetActivationEpoch(SupernovaFlag) == epoch && eeh.IsFlagEnabledInEpoch(SupernovaFlag, epoch)
+	log.Info("SetSuperNovaActivationRound", "currentRound", round, "activationRound", round+20, "epoch", epoch, "is enabled in current round", isEnabled)
+	if isEnabled {
+		supernovaRound := round + 20
+		erh.SetActivationRound(SupernovaRoundFlag, supernovaRound)
+		pch.SetActivationRound(supernovaRound, log)
+		cch.SetActivationRound(supernovaRound, log)
+	}
+}

common/configs/commonConfigs.go

@@ -5,6 +5,7 @@ import (
 	"sort"
 
 	"github.com/multiversx/mx-chain-go/config"
+	logger "github.com/multiversx/mx-chain-logger-go"
 )
 
 const (
@@ -188,3 +189,10 @@ func (cc *commonConfigs) GetNumRoundsToWaitBeforeSignalingChronologyStuck(epoch
 func (cc *commonConfigs) IsInterfaceNil() bool {
 	return cc == nil
 }
+
+// SetActivationRound -
+func (cc *commonConfigs) SetActivationRound(round uint64, log logger.Logger) {
+	nr := len(cc.orderedEpochStartConfigByRound)
+	log.Info("commonConfigs.SetActivationRound", "enableRound", round, "oldRound", cc.orderedEpochStartConfigByRound[nr-1].EnableRound)
+	cc.orderedEpochStartConfigByRound[nr-1].EnableRound = round
+}

common/configs/processConfigs.go

@@ -294,3 +294,10 @@ func (pce *processConfigsByEpoch) getValueByRound(
 func (pce *processConfigsByEpoch) IsInterfaceNil() bool {
 	return pce == nil
 }
+
+// SetActivationRound -
+func (pce *processConfigsByEpoch) SetActivationRound(round uint64, log logger.Logger) {
+	nr := len(pce.orderedConfigByRound)
+	log.Info("processConfigsByEpoch.SetActivationRound", "enableRound", round, "oldRound", pce.orderedConfigByRound[nr-1].EnableRound)
+	pce.orderedConfigByRound[nr-1].EnableRound = round
+}

common/constants.go

@@ -64,7 +64,7 @@ const DisabledShardIDAsObserver = uint32(0xFFFFFFFF) - 7
 
 // MaxTxNonceDeltaAllowed specifies the maximum difference between an account's nonce and a received transaction's nonce
 // in order to mark the transaction as valid.
-const MaxTxNonceDeltaAllowed = 100
+const MaxTxNonceDeltaAllowed = 100000
 
 // MaxBulkTransactionSize specifies the maximum size of one bulk with txs which can be send over the network
 // TODO convert this const into a var and read it from config when this code moves to another binary

common/enablers/enableRoundsHandler.go

@@ -174,3 +174,14 @@ func (handler *enableRoundsHandler) GetActivationRound(flag common.EnableRoundFl
 func (handler *enableRoundsHandler) IsInterfaceNil() bool {
 	return handler == nil
 }
+
+// SetActivationRound sets the activation round of the provided flag
+func (handler *enableRoundsHandler) SetActivationRound(flag common.EnableRoundFlag, round uint64) {
+	handler.allFlagsDefined[flag] = roundFlagHandler{
+		isActiveInRound: func(r uint64) bool {
+			return r >= round
+		},
+		activationRound: round,
+	}
+	log.Debug("SetActivationRound", "flag", flag, "round", round)
+}

common/interface.go

@@ -10,6 +10,7 @@ import (
 	"github.com/multiversx/mx-chain-core-go/data/block"
 	crypto "github.com/multiversx/mx-chain-crypto-go"
 	"github.com/multiversx/mx-chain-go/common/configs/dto"
+	logger "github.com/multiversx/mx-chain-logger-go"
 
 	"github.com/multiversx/mx-chain-go/config"
 )
@@ -493,6 +494,8 @@ type ProcessConfigsHandler interface {
 
 	GetValue(variable dto.ConfigVariable) uint64
 
+	SetActivationRound(round uint64, log logger.Logger)
+
 	IsInterfaceNil() bool
 }
 
@@ -503,5 +506,7 @@ type CommonConfigsHandler interface {
 	GetMaxRoundsWithoutCommittedStartInEpochBlockInRound(round uint64) uint32
 	GetNumRoundsToWaitBeforeSignalingChronologyStuck(epoch uint32) uint32
 
+	SetActivationRound(round uint64, log logger.Logger)
+
 	IsInterfaceNil() bool
 }

consensus/round/round.go

@@ -42,7 +42,7 @@ type round struct {
 	syncTimer                 ntp.SyncTimer
 	startRound                int64
 	supernovaStartRound       int64
-
+	initialGenesisTime        time.Time
 	*sync.RWMutex
 
 	enableRoundsHandler common.EnableRoundsHandler
@@ -70,6 +70,7 @@ func NewRound(args ArgsRound) (*round, error) {
 		genesisTimeStamp:          args.GenesisTimeStamp,
 		RWMutex:                   &sync.RWMutex{},
 		enableRoundsHandler:       args.EnableRoundsHandler,
+		initialGenesisTime:        args.GenesisTimeStamp,
 	}
 	rnd.UpdateRound(args.GenesisTimeStamp, args.CurrentTimeStamp)
 
@@ -78,9 +79,25 @@ func NewRound(args ArgsRound) (*round, error) {
 	return &rnd, nil
 }
 
+func (rnd *round) GetSupernovaGenesisTimestamp() time.Time {
+	supernovaStartRound := int64(rnd.enableRoundsHandler.GetActivationRound(common.SupernovaRoundFlag))
+	if supernovaStartRound != rnd.supernovaStartRound {
+		log.Debug("round.go: GetSupernovaGenesisTimestamp: force set supernovaStartRound",
+			"initialGenesisTime", rnd.initialGenesisTime,
+			"timeDuration", rnd.timeDuration.Nanoseconds(),
+			"supernovaStartRound", supernovaStartRound,
+			"oldSuperNovaStartRound", rnd.supernovaStartRound)
+		rnd.supernovaStartRound = supernovaStartRound
+		rnd.supernovaGenesisTimeStamp = rnd.initialGenesisTime.Add(time.Duration(supernovaStartRound * rnd.timeDuration.Nanoseconds()))
+		log.Debug("round.go: GetSupernovaGenesisTimestamp: force set supernovaStartRound", "round", supernovaStartRound, "supernovaGenesisTimeStamp", rnd.supernovaGenesisTimeStamp)
+	}
+
+	return rnd.supernovaGenesisTimeStamp
+}
+
 // UpdateRound updates the index and the time stamp of the round depending on the genesis time and the current time given
 func (rnd *round) UpdateRound(genesisTimeStamp time.Time, currentTimeStamp time.Time) {
-	baseTimeStamp := rnd.supernovaGenesisTimeStamp
+	baseTimeStamp := rnd.GetSupernovaGenesisTimestamp()
 	roundDuration := rnd.supernovaTimeDuration
 	startRound := rnd.supernovaStartRound
 
@@ -113,7 +130,7 @@ func (rnd *round) isSupernovaActivated(currentTimeStamp time.Time) bool {
 		return supernovaActivated
 	}
 
-	currentTimeAfterSupernova := currentTimeStamp.UnixMilli() >= rnd.supernovaGenesisTimeStamp.UnixMilli()
+	currentTimeAfterSupernova := currentTimeStamp.UnixMilli() >= rnd.GetSupernovaGenesisTimestamp().UnixMilli()
 
 	if currentTimeAfterSupernova {
 		log.Debug("isSupernovaActivated: force set supernovaActivated",

consensus/spos/bls/constants.go

@@ -33,6 +33,36 @@
 	MtInvalidSigners
 )
 
+// waitingAllSigsMaxTimeThreshold specifies the max allocated time for waiting all signatures from the total time of the subround signature
+const waitingAllSigsMaxTimeThreshold = 0.5
+
+// processingThresholdPercent specifies the max allocated time for processing the block as a percentage of the total time of the round
+const processingThresholdPercent = 85
+
+// srStartStartTime specifies the start time, from the total time of the round, of Subround Start
+const srStartStartTime = 0.0
+
+// srEndStartTime specifies the end time, from the total time of the round, of Subround Start
+const srStartEndTime = 0.05
+
+// srBlockStartTime specifies the start time, from the total time of the round, of Subround Block
+const srBlockStartTime = 0.05
+
+// srBlockEndTime specifies the end time, from the total time of the round, of Subround Block
+const srBlockEndTime = 0.45
+
+// srSignatureStartTime specifies the start time, from the total time of the round, of Subround Signature
+const srSignatureStartTime = 0.45
+
+// srSignatureEndTime specifies the end time, from the total time of the round, of Subround Signature
+const srSignatureEndTime = 0.85
+
+// srEndStartTime specifies the start time, from the total time of the round, of Subround End
+const srEndStartTime = 0.85
+
+// srEndEndTime specifies the end time, from the total time of the round, of Subround End
+const srEndEndTime = 0.95
+
 const (
 	// BlockBodyAndHeaderStringValue represents the string to be used to identify a block body and a block header
 	BlockBodyAndHeaderStringValue = "(BLOCK_BODY_AND_HEADER)"

consensus/spos/bls/v1/subroundSignature.go

@@ -144,7 +144,7 @@ func (sr *subroundSignature) createAndSendSignatureMessage(signatureShare []byte
 		return false
 	}
 
-	log.Debug("step 2: signature has been sent", "pk", pkBytes)
+	//log.Debug("step 2: signature has been sent", "pk", pkBytes)
 
 	return true
 }

consensus/spos/bls/v2/subroundSignature.go

@@ -143,7 +143,7 @@ func (sr *subroundSignature) createAndSendSignatureMessage(signatureShare []byte
 		return false
 	}
 
-	log.Debug("step 2: signature has been sent", "pk", pkBytes)
+	//log.Debug("step 2: signature has been sent", "pk", pkBytes)
 
 	return true
 }

consensus/spos/consensusMessageValidator.go

@@ -144,12 +144,6 @@ func (cmv *consensusMessageValidator) checkConsensusMessageValidity(cnsMsg *cons
 			len(cnsMsg.PubKey))
 	}
 
-	if len(cnsMsg.Signature) != cmv.signatureSize {
-		return fmt.Errorf("%w : received signature from consensus topic has an invalid size: %d",
-			ErrInvalidSignatureSize,
-			len(cnsMsg.Signature))
-	}
-
 	isNodeInEligibleList := cmv.consensusState.IsNodeInEligibleList(string(cnsMsg.PubKey))
 	if !isNodeInEligibleList {
 		return fmt.Errorf("%w : received message from consensus topic has an invalid public key: %s",
@@ -404,11 +398,11 @@ func (cmv *consensusMessageValidator) checkMessageWithSignatureValidity(cnsMsg *
 			logger.DisplayByteSlice(cnsMsg.PubKey))
 	}
 
-	if len(cnsMsg.SignatureShare) != cmv.signatureSize {
-		return fmt.Errorf("%w : received signature share from consensus topic has an invalid size: %d",
-			ErrInvalidSignatureSize,
-			len(cnsMsg.SignatureShare))
-	}
+	//if len(cnsMsg.SignatureShare) != cmv.signatureSize {
+	//	return fmt.Errorf("%w : received signature share from consensus topic has an invalid size: %d",
+	//		ErrInvalidSignatureSize,
+	//		len(cnsMsg.SignatureShare))
+	//}
 
 	return nil
 }
@@ -437,23 +431,6 @@ func (cmv *consensusMessageValidator) checkMessageWithFinalInfoValidity(cnsMsg *
 			len(cnsMsg.PubKeysBitmap))
 	}
 
-	if len(cnsMsg.AggregateSignature) != cmv.signatureSize {
-		return fmt.Errorf("%w : received aggregate signature from consensus topic has an invalid size: %d",
-			ErrInvalidSignatureSize,
-			len(cnsMsg.AggregateSignature))
-	}
-
-	// TODO[cleanup cns finality]: remove this
-	if cmv.shouldNotVerifyLeaderSignature() {
-		return nil
-	}
-
-	if len(cnsMsg.LeaderSignature) != cmv.signatureSize {
-		return fmt.Errorf("%w : received leader signature from consensus topic has an invalid size: %d",
-			ErrInvalidSignatureSize,
-			len(cnsMsg.LeaderSignature))
-	}
-
 	return nil
 }
 

epochStart/metachain/trigger.go

@@ -280,10 +280,12 @@ func (t *trigger) setEpochChange(round uint64) {
 	t.currEpochStartRound = round
 
 	msg := fmt.Sprintf("EPOCH %d BEGINS IN ROUND (%d)", t.epoch, t.currEpochStartRound)
+	common.SetSuperNovaActivationRound(t.epoch, round)
 	log.Debug(display.Headline(msg, "", "#"))
 	log.Debug("trigger.Update", "isEpochStart", t.isEpochStart)
 	logger.SetCorrelationEpoch(t.epoch)
 	t.nextEpochStartRound = disabledRoundForForceEpochStart
+
 }
 
 // SetProcessed sets start of epoch to false and cleans underlying structure

epochStart/shardchain/trigger.go

@@ -742,6 +742,7 @@ func (t *trigger) updateTriggerFromMeta() {
 			t.epochStartNotifier.NotifyEpochChangeConfirmed(t.metaEpoch)
 
 			msg := fmt.Sprintf("EPOCH %d BEGINS IN ROUND (%d)", t.metaEpoch, t.epochStartRound)
+			common.SetSuperNovaActivationRound(t.metaEpoch, t.epochStartRound)
 			log.Debug(display.Headline(msg, "", "#"))
 			log.Debug("trigger.updateTriggerFromMeta", "isEpochStart", t.isEpochStart)
 			logger.SetCorrelationEpoch(t.metaEpoch)

factory/core/coreComponents.go

@@ -233,6 +233,11 @@ func (ccf *coreComponentsFactory) Create() (*coreComponents, error) {
 		return nil, fmt.Errorf("%w for processConfigsByEpoch", err)
 	}
 
+	common.SetEnableEpochsHandler(enableEpochsHandler)
+	common.SetEnableRoundsHandler(enableRoundsHandler)
+	common.SetProcessConfigsHandler(processConfigs)
+	common.SetCommonConfigsHandler(commonConfigsHandler)
+
 	genesisNodesConfig, err := sharding.NewNodesSetup(
 		ccf.nodesSetupConfig,
 		chainParametersHandler,