New feature 25 "Deterministic Finality and Ride V9" added.

.github/workflows/go.yml

@@ -46,12 +46,19 @@ jobs:
         with:
           version: latest
           args: -c .golangci.yml
+
       # Strict linter configuration, only checking new code from pull requests.
       - name: golangci-lint-strict
         run: golangci-lint run -c .golangci-strict.yml --new-from-rev=origin/master
+
       # Check for modern Go code patterns
-      - name: modernize check
-        run: go run golang.org/x/tools/gopls/internal/analysis/modernize/cmd/modernize@v0.20.0 ./...
+      - name: Run modernize
+        shell: bash
+        run: |
+          set +o pipefail
+          go run golang.org/x/tools/go/analysis/passes/modernize/cmd/modernize@latest ./... 2>&1 | \
+            grep -vE '\.(pb|gen)\.go|mock|_string.go|^exit status|^go: downloading' | \
+            { output=$(cat); [ -n "$output" ] && { echo "$output"; exit 1; } || exit 0; }
 
   build:
     name: ubuntu

.github/workflows/security.yml

@@ -35,15 +35,15 @@ jobs:
         uses: securego/gosec@223e19b8856e00f02cc67804499a83f77e208f3c # v2.25.0
         with:
           # with '-no-fail' we let the report trigger content trigger a failure using the GitHub Security features.
-          args: "-no-fail -fmt sarif -out gosec.sarif ./..."
+          args: "-no-fail -exclude-generated -fmt sarif -out gosec.sarif ./..."
       - name: Transform gosec SARIF to meet SARIF 2.1.0 schema requirements
         # Produces SARIF file has two incompatibilities with SARIF 2.1.0 schema all of them are in `fixes` object:
         #  1. Field `description` contains only `markdown` property, but `text` property is mandatory.
         #  2. Property `artifactChanges` must be non-empty array with valid `artifactChange` object.
         # To fix those issues the first part of jq query copies content of `markdown` field into `text` field
         # if it's not present. In the second part if the `fixes` object has null array as `artifactChanges` the empty
         # valid `artifactChange` object inserted.
-        # After fix of mentioned gosec issues this step can be removed. 
+        # After fix of mentioned gosec issues this step can be removed.
         run: |
           set -e
           jq 'walk(if type=="object" and has("markdown") and (.text == null or .text == "") then .text = .markdown else . end) | (.runs[].results[]? .fixes[]? .artifactChanges) |= (if . == null then [{"artifactLocation": { "uri": "" }, "replacements": [{"deletedRegion": {"byteOffset": 0, "byteLength": 0 }}]}] else . end)' gosec.sarif > gosec_fixed.sarif

.gitmodules

@@ -1,3 +1,4 @@
 [submodule "pkg/grpc/protobuf-schemas"]
 	path = pkg/grpc/protobuf-schemas
 	url = https://github.com/wavesplatform/protobuf-schemas
+	branch = deterministic-finality

.golangci-strict.yml

@@ -156,6 +156,10 @@ linters:
         - github.com/jmoiron/sqlx
     usetesting:
       os-setenv: true
+    revive:
+      rules:
+        - name: var-naming
+          disable: true
   exclusions:
     generated: lax
     presets:

.golangci.yml

@@ -1,11 +1,16 @@
 version: "2"
 linters:
+  enable:
+    - exhaustive
   settings:
     cyclop:
       max-complexity: 30
       package-average: 10
     errcheck:
       check-type-assertions: false
+    exhaustive:
+      check:
+        - switch
     exhaustruct:
       exclude:
         - ^net/http.Client$

.semgrepignore

@@ -18,3 +18,6 @@ cmd/wmd/internal/swagger/
 
 # Ignore testdata folders
 pkg/state/testdata/
+
+# Ignore generated files
+**/*.pb.go

cmd/node/node.go

@@ -32,6 +32,7 @@ import (
 	"github.com/wavesplatform/gowaves/pkg/logging"
 	"github.com/wavesplatform/gowaves/pkg/metrics"
 	"github.com/wavesplatform/gowaves/pkg/miner"
+	"github.com/wavesplatform/gowaves/pkg/miner/endorsementpool"
 	"github.com/wavesplatform/gowaves/pkg/miner/scheduler"
 	"github.com/wavesplatform/gowaves/pkg/miner/utxpool"
 	"github.com/wavesplatform/gowaves/pkg/node"
@@ -467,7 +468,7 @@ func runNode(ctx context.Context, nc *config) (_ io.Closer, retErr error) {
 		return nil, errors.Wrap(err, "failed to create services")
 	}
 
-	app, err := api.NewApp(nc.apiKey, minerScheduler, svs)
+	app, err := api.NewApp(nc.apiKey, minerScheduler, svs, cfg)
 	if err != nil {
 		return nil, errors.Wrap(err, "failed to initialize application")
 	}
@@ -480,7 +481,7 @@ func runNode(ctx context.Context, nc *config) (_ io.Closer, retErr error) {
 		return nil, errors.Wrap(apiErr, "failed to run APIs")
 	}
 
-	return startNode(ctx, nc, svs, features, minerScheduler, parent, declAddr, nl), nil
+	return startNode(ctx, nc, svs, features, minerScheduler, parent, declAddr, nl, cfg.GenerationPeriod), nil
 }
 
 func startNode(
@@ -492,6 +493,7 @@ func startNode(
 	parent peer.Parent,
 	declAddr proto.TCPAddr,
 	nl *slog.Logger,
+	periodGeneration uint64,
 ) *node.Node {
 	bindAddr := proto.NewTCPAddrFromString(nc.bindAddress)
 
@@ -504,7 +506,7 @@ func startNode(
 	go ntw.Run(ctx)
 
 	n := node.NewNode(svs, declAddr, bindAddr, nc.microblockInterval, nc.enableLightMode, nl, fl)
-	go n.Run(ctx, parent, svs.InternalChannel, networkInfoCh, ntw.SyncPeer())
+	go n.Run(ctx, parent, svs.InternalChannel, networkInfoCh, ntw.SyncPeer(), periodGeneration)
 	return n
 }
 
@@ -808,12 +810,17 @@ func createServices(
 	if err != nil {
 		return services.Services{}, errors.Wrap(err, "failed to initialize UTX")
 	}
+	endorsementsPool, err := endorsementpool.NewEndorsementPool(cfg.MaxEndorsements)
+	if err != nil {
+		return services.Services{}, errors.Wrap(err, "failed to initialize endorsement pool")
+	}
 	return services.Services{
 		State:           st,
 		Peers:           peerManager,
 		Scheduler:       scheduler,
 		BlocksApplier:   blocks_applier.NewBlocksApplier(),
 		UtxPool:         utxpool.New(utxPoolMaxSizeBytes, utxValidator, cfg),
+		EndorsementPool: endorsementsPool,
 		Scheme:          cfg.AddressSchemeCharacter,
 		Time:            ntpTime,
 		Wallet:          wal,

cmd/rollback/main.go

@@ -94,7 +94,7 @@ func run() error {
 
 	slog.Info("Current height", "height", curHeight)
 
-	err = s.RollbackToHeight(*height)
+	err = s.RollbackToHeight(*height, false)
 	if err != nil {
 		return fmt.Errorf("failed to rollback: %w", err)
 	}

cmd/statecmp/statecmp.go

@@ -15,6 +15,7 @@ import (
 	"github.com/pkg/errors"
 
 	"github.com/wavesplatform/gowaves/pkg/client"
+	"github.com/wavesplatform/gowaves/pkg/crypto"
 	"github.com/wavesplatform/gowaves/pkg/logging"
 	"github.com/wavesplatform/gowaves/pkg/proto"
 )
@@ -43,10 +44,10 @@ func checkAndUpdateURL(s string) (string, error) {
 	return u.String(), nil
 }
 
-func loadStateHash(ctx context.Context, cl *client.Client, height uint64, tries int) (*proto.StateHash, error) {
+func loadStateHash(ctx context.Context, cl *client.Client, height uint64, tries int) (proto.StateHash, error) {
 	ctx, cancel := context.WithTimeout(ctx, 60*time.Second)
 	defer cancel()
-	var sh *proto.StateHash
+	var sh proto.StateHash
 	var err error
 	for range tries {
 		sh, _, err = cl.Debug.StateHash(ctx, height)
@@ -61,12 +62,12 @@ type printer struct {
 	lock sync.Mutex
 }
 
-func (p *printer) printDifferentResults(height uint64, res map[proto.FieldsHashes]*nodesGroup) {
+func (p *printer) printDifferentResults(height uint64, res map[crypto.Digest]*nodesGroup) {
 	p.lock.Lock()
 	defer p.lock.Unlock()
 
-	for fh, nodes := range res {
-		hashJs, err := json.Marshal(fh)
+	for sh, nodes := range res {
+		hashJs, err := json.Marshal(sh)
 		if err != nil {
 			panic(err)
 		}
@@ -76,7 +77,7 @@ func (p *printer) printDifferentResults(height uint64, res map[proto.FieldsHashe
 }
 
 type stateHashInfo struct {
-	hash *proto.StateHash
+	sh   proto.StateHash
 	node string
 }
 
@@ -87,12 +88,13 @@ type hashResult struct {
 
 type nodesGroup struct {
 	nodes []string
+	sh    proto.StateHash
 }
 
-func newNodesGroup(first string) *nodesGroup {
+func newNodesGroup(first string, sh proto.StateHash) *nodesGroup {
 	nodes := make([]string, 1)
 	nodes[0] = first
-	return &nodesGroup{nodes: nodes}
+	return &nodesGroup{nodes: nodes, sh: sh}
 }
 
 func (ng *nodesGroup) addNode(node string) {
@@ -112,27 +114,27 @@ func manageHeight(
 			sh, err := loadStateHash(ctx, cl, height, tries)
 			res := hashResult{
 				res: stateHashInfo{
-					hash: sh,
+					sh:   sh,
 					node: node,
 				},
 				err: err,
 			}
 			results <- res
 		}(cl, node)
 	}
-	differentResults := make(map[proto.FieldsHashes]*nodesGroup)
+	differentResults := make(map[crypto.Digest]*nodesGroup)
 	for range clients {
 		hr := <-results
 		if hr.err != nil {
 			cancel()
 			return hr.err
 		}
-		fh := hr.res.hash.FieldsHashes
-		nodesGroup, ok := differentResults[fh]
+		sh := hr.res.sh
+		ng, ok := differentResults[sh.GetSumHash()]
 		if !ok {
-			differentResults[fh] = newNodesGroup(hr.res.node)
+			differentResults[sh.GetSumHash()] = newNodesGroup(hr.res.node, sh)
 		} else {
-			nodesGroup.addNode(hr.res.node)
+			ng.addNode(hr.res.node)
 		}
 	}
 	if len(differentResults) != 1 {

cmd/statehash/statehash.go

@@ -252,7 +252,7 @@ func findLastEqualStateHashes(
 ) (uint64, error) {
 	var err error
 	var r uint64
-	var lsh, rsh *proto.StateHashDebug
+	var lsh, rsh proto.StateHashDebug
 	var start uint64 = 1
 	for start <= stop {
 		middle := (start + stop) / 2
@@ -279,7 +279,7 @@ func findLastEqualStateHashes(
 	return r, nil
 }
 
-func stateHashToString(sh *proto.StateHashDebug) string {
+func stateHashToString(sh proto.StateHashDebug) string {
 	js, err := json.Marshal(sh)
 	if err != nil {
 		slog.Error("Failed to render state hash to text", logging.Error(err))
@@ -288,24 +288,25 @@ func stateHashToString(sh *proto.StateHashDebug) string {
 	return string(js)
 }
 
-func compareStateHashes(sh1, sh2 *proto.StateHashDebug, onlyLegacy bool) (bool, error) {
-	if sh1.BlockID != sh2.BlockID {
-		return false, fmt.Errorf("different block IDs: '%s' != '%s'", sh1.BlockID.String(), sh2.BlockID.String())
+func compareStateHashes(sh1, sh2 proto.StateHashDebug, onlyLegacy bool) (bool, error) {
+	if sh1.GetBlockID() != sh2.GetBlockID() {
+		return false, fmt.Errorf("different block IDs: '%s' != '%s'",
+			sh1.GetBlockID().String(), sh2.GetBlockID().String())
 	}
-	legacyEqual := sh1.SumHash == sh2.SumHash
+	legacyEqual := sh1.GetSumHash() == sh2.GetSumHash()
 	if onlyLegacy {
 		return legacyEqual, nil
 	}
-	return legacyEqual && sh1.SnapshotHash == sh2.SnapshotHash, nil
+	return legacyEqual && sh1.GetSnapshotHash() == sh2.GetSnapshotHash(), nil
 }
 
 func compareWithRemote(
 	ctx context.Context,
-	sh *proto.StateHashDebug,
+	sh proto.StateHashDebug,
 	c *client.Client,
 	h uint64,
 	onlyLegacy bool,
-) (bool, *proto.StateHashDebug, error) {
+) (bool, proto.StateHashDebug, error) {
 	rsh, err := getRemoteStateHash(ctx, c, h)
 	if err != nil {
 		return false, nil, err
@@ -314,15 +315,15 @@ func compareWithRemote(
 	return ok, rsh, err
 }
 
-func getRemoteStateHash(ctx context.Context, c *client.Client, h uint64) (*proto.StateHashDebug, error) {
+func getRemoteStateHash(ctx context.Context, c *client.Client, h uint64) (proto.StateHashDebug, error) {
 	sh, _, err := c.Debug.StateHashDebug(ctx, h)
 	if err != nil {
 		return nil, fmt.Errorf("failed to get state hash at %d height: %w", h, err)
 	}
 	return sh, nil
 }
 
-func getLocalStateHash(st state.StateInfo, h uint64) (*proto.StateHashDebug, error) {
+func getLocalStateHash(st state.StateInfo, h uint64) (proto.StateHashDebug, error) {
 	const localVersion = "local"
 	lsh, err := st.LegacyStateHashAtHeight(h)
 	if err != nil {
@@ -332,8 +333,15 @@ func getLocalStateHash(st state.StateInfo, h uint64) (*proto.StateHashDebug, err
 	if err != nil {
 		return nil, fmt.Errorf("failed to get snapshot state hash at %d height: %w", h, err)
 	}
-	shd := proto.NewStateHashJSDebug(*lsh, h, localVersion, snapSH)
-	return &shd, nil
+	finalityActivated, err := st.IsActiveAtHeight(int16(settings.DeterministicFinality), h)
+	if err != nil {
+		return nil, fmt.Errorf("failed to determine finality activation at %d height: %w", h, err)
+	}
+	bh, bhErr := st.BlockByHeight(h)
+	if bhErr != nil {
+		return nil, fmt.Errorf("failed to get block at %d height: %w", h, bhErr)
+	}
+	return proto.NewStateHashDebug(finalityActivated, lsh, h, localVersion, snapSH, bh.BaseTarget)
 }
 
 func showUsage() {

cmd/wallet/main.go

@@ -449,11 +449,11 @@ func createWallet(
 		return errors.Wrap(err, "failed to write the wallet's data to the wallet")
 
 	}
-	fmt.Printf("New account has been added to wallet successfully %s\n", walletPath) //nolint:forbidigo // As intended
-	fmt.Printf("Account Seed:   %s\n", walletCredentials.accountSeed.String())
-	fmt.Printf("Public Key:     %s\n", walletCredentials.pk.String())
-	fmt.Printf("Secret Key:     %s\n", walletCredentials.sk.String())
-	fmt.Printf("Address:        %s\n", walletCredentials.address.String())
+	fmt.Fprintf(os.Stdout, "New account has been added to wallet successfully %s\n", walletPath)
+	fmt.Fprintf(os.Stdout, "Account Seed:   %s\n", walletCredentials.accountSeed.String())
+	fmt.Fprintf(os.Stdout, "Public Key:     %s\n", walletCredentials.pk.String())
+	fmt.Fprintf(os.Stdout, "Secret Key:     %s\n", walletCredentials.sk.String())
+	fmt.Fprintf(os.Stdout, "Address:        %s\n", walletCredentials.address.String())
 	return nil
 }
 

go.mod

@@ -9,6 +9,7 @@ require (
 	github.com/ccoveille/go-safecast/v2 v2.0.0
 	github.com/cenkalti/backoff/v4 v4.3.0
 	github.com/cespare/xxhash/v2 v2.3.0
+	github.com/cloudflare/circl v1.6.3
 	github.com/consensys/gnark v0.14.0
 	github.com/consensys/gnark-crypto v0.19.2
 	github.com/coocood/freecache v1.2.7
@@ -50,7 +51,7 @@ require (
 	go.uber.org/atomic v1.11.0
 	go.uber.org/goleak v1.3.0
 	golang.org/x/crypto v0.49.0
-	golang.org/x/exp v0.0.0-20251023183803-a4bb9ffd2546
+	golang.org/x/exp v0.0.0-20260218203240-3dfff04db8fa
 	golang.org/x/sync v0.20.0
 	golang.org/x/sys v0.42.0
 	google.golang.org/grpc v1.79.3

go.sum

@@ -36,6 +36,8 @@ github.com/cenkalti/backoff/v4 v4.3.0/go.mod h1:Y3VNntkOUPxTVeUxJ/G5vcM//AlwfmyY
 github.com/cespare/xxhash/v2 v2.1.1/go.mod h1:VGX0DQ3Q6kWi7AoAeZDth3/j3BFtOZR5XLFGgcrjCOs=
 github.com/cespare/xxhash/v2 v2.3.0 h1:UL815xU9SqsFlibzuggzjXhog7bL6oX9BbNZnL2UFvs=
 github.com/cespare/xxhash/v2 v2.3.0/go.mod h1:VGX0DQ3Q6kWi7AoAeZDth3/j3BFtOZR5XLFGgcrjCOs=
+github.com/cloudflare/circl v1.6.3 h1:9GPOhQGF9MCYUeXyMYlqTR6a5gTrgR/fBLXvUgtVcg8=
+github.com/cloudflare/circl v1.6.3/go.mod h1:2eXP6Qfat4O/Yhh8BznvKnJ+uzEoTQ6jVKJRn81BiS4=
 github.com/cockroachdb/apd v1.1.0/go.mod h1:8Sl8LxpKi29FqWXR16WEFZRNSz3SoPzUzeMeY4+DwBQ=
 github.com/consensys/gnark v0.14.0 h1:RG+8WxRanFSFBSlmCDRJnYMYYKpH3Ncs5SMzg24B5HQ=
 github.com/consensys/gnark v0.14.0/go.mod h1:1IBpDPB/Rdyh55bQRR4b0z1WvfHQN1e0020jCvKP2Gk=
@@ -358,8 +360,8 @@ golang.org/x/crypto v0.0.0-20200622213623-75b288015ac9/go.mod h1:LzIPMQfyMNhhGPh
 golang.org/x/crypto v0.0.0-20200728195943-123391ffb6de/go.mod h1:LzIPMQfyMNhhGPhUkYOs5KpL4U8rLKemX1yGLhDgUto=
 golang.org/x/crypto v0.49.0 h1:+Ng2ULVvLHnJ/ZFEq4KdcDd/cfjrrjjNSXNzxg0Y4U4=
 golang.org/x/crypto v0.49.0/go.mod h1:ErX4dUh2UM+CFYiXZRTcMpEcN8b/1gxEuv3nODoYtCA=
-golang.org/x/exp v0.0.0-20251023183803-a4bb9ffd2546 h1:mgKeJMpvi0yx/sU5GsxQ7p6s2wtOnGAHZWCHUM4KGzY=
-golang.org/x/exp v0.0.0-20251023183803-a4bb9ffd2546/go.mod h1:j/pmGrbnkbPtQfxEe5D0VQhZC6qKbfKifgD0oM7sR70=
+golang.org/x/exp v0.0.0-20260218203240-3dfff04db8fa h1:Zt3DZoOFFYkKhDT3v7Lm9FDMEV06GpzjG2jrqW+QTE0=
+golang.org/x/exp v0.0.0-20260218203240-3dfff04db8fa/go.mod h1:K79w1Vqn7PoiZn+TkNpx3BUWUQksGO3JcVX6qIjytmA=
 golang.org/x/mod v0.3.0/go.mod h1:s0Qsj1ACt9ePp/hMypM3fl4fZqREWJwdYDEqhRiZZUA=
 golang.org/x/net v0.0.0-20181114220301-adae6a3d119a/go.mod h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4=
 golang.org/x/net v0.0.0-20190311183353-d8887717615a/go.mod h1:t9HGtf8HONx5eT2rtn7q6eTqICYqUVnKs3thJo3Qplg=