Skip to content
Merged
Show file tree
Hide file tree
Changes from 1 commit
Commits
Show all changes
57 commits
Select commit Hold shift + click to select a range
d4c7e7d
Add high availabiliy via raft
alpe Nov 12, 2025
820b9a3
Prefent duplicate peers
alpe Nov 12, 2025
35cf0c8
Merge branch 'main' into alex/adr023_ha-failover_raft7
alpe Nov 17, 2025
45a6e27
Go mod tidy
alpe Nov 17, 2025
3111158
Merge branch 'main' into alex/adr023_ha-failover_raft7
alpe Nov 17, 2025
4562ded
Minor updates
alpe Nov 17, 2025
4d47754
Merge branch 'main' into alex/adr023_ha-failover_raft7
alpe Nov 18, 2025
0804346
Fix test
alpe Nov 18, 2025
1c2e3f1
Leadership fix
alpe Nov 18, 2025
c320a7a
Fix test
alpe Nov 18, 2025
72ec5fe
Remove sleep
alpe Nov 19, 2025
b34d7a0
Increase buffer size for raft msgs
alpe Nov 19, 2025
7af5d1a
Merge branch 'main' into alex/adr023_ha-failover_raft7
alpe Nov 20, 2025
406377e
Review feedback
alpe Nov 20, 2025
0ff25b8
Merge branch 'main' into alex/adr023_ha-failover_raft7
alpe Nov 20, 2025
b92a67f
Merge branch 'main' into alex/adr023_ha-failover_raft7
alpe Nov 21, 2025
406ad8b
Add replace to go.mod
alpe Nov 21, 2025
1337bc6
Merge branch 'main' into alex/adr023_ha-failover_raft7
alpe Nov 24, 2025
abfa8d3
Fix merge conflicts
alpe Nov 24, 2025
aebbdff
Linter fix
alpe Nov 24, 2025
50d7caf
Minor test update
alpe Nov 24, 2025
5de9f0e
Remove store.Sync
alpe Nov 25, 2025
30094b2
Merge branch 'main' into alex/adr023_ha-failover_raft7
alpe Dec 3, 2025
695324e
Merge
alpe Dec 3, 2025
2463919
Add last submitted da heights to raft
alpe Dec 3, 2025
3e1cbca
Make test compile again
alpe Dec 4, 2025
567092f
Merge branch 'main' into alex/adr023_ha-failover_raft8
alpe Jan 6, 2026
640924b
Complete merge
alpe Jan 6, 2026
11038cd
Merge branch 'main' into alex/adr023_ha-failover_raft8
alpe Jan 7, 2026
095f882
Fix integration test
alpe Jan 7, 2026
99afdad
Review feedback and linting
alpe Jan 7, 2026
3f7f431
Convert raft state into proto type
alpe Jan 7, 2026
25a6185
Fix import and e2e tests
alpe Jan 8, 2026
adc05ed
Cufigurable leader_lease_timeout
alpe Jan 8, 2026
9b0bff4
Merge branch 'main' into alex/adr023_ha-failover_raft8
alpe Jan 9, 2026
49ba50f
Log raft state height when passing leadership
alpe Jan 9, 2026
00ae050
Recover with raft state
alpe Jan 12, 2026
490b286
Ensure block hash in state check
alpe Jan 12, 2026
d7fbf79
Merge branch 'main' into alex/adr023_ha-failover_raft8
alpe Jan 12, 2026
dfa2204
Merge branch 'main' into alex/adr023_ha-failover_raft8
alpe Jan 15, 2026
7edca17
x
alpe Jan 14, 2026
6502a47
More safety features, including db.sync
alpe Jan 14, 2026
a52d538
Ensure safe restart
alpe Jan 15, 2026
3203ce6
x
alpe Jan 15, 2026
1cf1167
Merge branch 'main' into alex/adr023_ha-failover_raft11
alpe Jan 16, 2026
e4e94f2
Resolve conflicts
alpe Jan 16, 2026
e444215
Fix test setup
alpe Jan 18, 2026
3b4fe3f
Fix dummyDA
alpe Jan 19, 2026
9b80c74
Merge branch 'main' into alex/adr023_ha-failover_raft11
alpe Jan 19, 2026
67d1ce7
Merge branch 'main' into alex/adr023_ha-failover_raft11
alpe Jan 26, 2026
51edca8
Review feedback
alpe Jan 26, 2026
5fc0b6b
Add grace period for test
alpe Jan 26, 2026
e8f9db0
Add raft doc
alpe Jan 27, 2026
c9b8166
Available ports for e2e tests
alpe Jan 27, 2026
acce8e4
Review feedback
alpe Jan 27, 2026
c1ef1d5
Merge branch 'main' into alex/adr023_ha-failover_raft11
alpe Jan 27, 2026
938f908
Fix integration test
alpe Jan 27, 2026
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
Merge branch 'main' into alex/adr023_ha-failover_raft11
* main:
  fix(docs): remove blog link from sidebar to fix 404 (#3014)
  build(deps): Bump github.com/cometbft/cometbft from 0.38.20 to 0.38.21 in /execution/evm/test in the go_modules group across 1 directory (#3011)
  refactor: use slices.Contains to simplify code (#3010)
  chore: Bump mermaid version and dependencies (#3009)
  chore: Bump github.com/consensys/gnark-crypto only (#3008)
  test: evm contract interaction (#3006)
  chore: remove redundant log (#3007)
  fix: return values correctly not nil (#3004)
  feat: expose execution client params to ev-node (#2982)
  feat(tracing): HTTP propagation (#3000)
  fix: deploy docs token (#3003)
  feat(tracing): add store tracing (#3001)
  feat: p2p exchange wrapper  (#2855)
  build(deps): Bump the all-go group across 5 directories with 5 updates (#2999)
  feat(tracing): adding forced inclusion tracing (#2997)
  chore: update calculator for strategies  (#2995)
  chore: adding tracing for da submitter (#2993)
  feat(tracing): part 10 da retriever tracing (#2991)
  chore: add da posting strategy to docs (#2992)
  • Loading branch information
alpe committed Jan 26, 2026
commit 67d1ce7ac51effd899b7b31649acb9c19d7f15f3
5 changes: 1 addition & 4 deletions .github/workflows/docs_deploy.yml
Original file line number Diff line number Diff line change
Expand Up @@ -13,9 +13,6 @@ on:
# Allows you to run this workflow manually from the Actions tab
workflow_dispatch:

# Sets permissions of the GITHUB_TOKEN to allow deployment to GitHub Pages
permissions: write-all

# Allow only one concurrent deployment, skipping runs queued between the run in-progress and latest queued.
# However, do NOT cancel in-progress runs as we want to allow these production deployments to complete.
concurrency:
Expand Down Expand Up @@ -49,6 +46,6 @@ jobs:
- name: Deploy to GitHub Pages
uses: peaceiris/actions-gh-pages@v4
with:
github_token: ${{ secrets.GITHUB_TOKEN }}
github_token: ${{ secrets.PAT_DOCS }}
publish_dir: ./docs/.vitepress/dist
cname: ev.xyz
12 changes: 12 additions & 0 deletions .mockery.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -44,11 +44,23 @@ packages:
filename: batch.go
github.com/celestiaorg/go-header:
interfaces:
Exchange:
config:
dir: ./test/mocks
pkgname: mocks
filename: external/hexchange.go
Store:
config:
dir: ./test/mocks
pkgname: mocks
filename: external/hstore.go
github.com/evstack/ev-node/pkg/sync:
interfaces:
P2PExchange:
config:
dir: ./test/mocks
pkgname: mocks
filename: external/p2pexchange.go
github.com/evstack/ev-node/block/internal/syncing:
interfaces:
DARetriever:
Expand Down
2 changes: 2 additions & 0 deletions CHANGELOG.md
Original file line number Diff line number Diff line change
Expand Up @@ -18,6 +18,8 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
Additionally, modified the core package to support marking transactions as forced included transactions.
The execution client ought to perform basic validation on those transactions as they have skipped the execution client's mempool.
- Add batching stategies (default stay time-based, unchanged with previous betas). Currently available strategies are `time`, `size`, `immediate` and `adaptive`.
- Added `FilterTxs` method to the execution interface. This method is meant to filter txs by size and if the execution clients allows it, by gas. This is useful for force included transactions, as those aren't filtered by the sequencer's mempool.
- Added `GetExecutionInfo` method to the execution interface. This method returns some execution information, such as the maximum gas per block.

### Changed

Expand Down
10 changes: 4 additions & 6 deletions apps/evm/cmd/run.go
Original file line number Diff line number Diff line change
Expand Up @@ -88,7 +88,7 @@ var RunCmd = &cobra.Command{
}

// Create sequencer based on configuration
sequencer, err := createSequencer(logger, datastore, nodeConfig, genesis, daClient)
sequencer, err := createSequencer(logger, datastore, nodeConfig, genesis, daClient, executor)
if err != nil {
return err
}
Expand Down Expand Up @@ -154,14 +154,15 @@ func createSequencer(
nodeConfig config.Config,
genesis genesis.Genesis,
daClient block.FullDAClient,
executor execution.Executor,
) (coresequencer.Sequencer, error) {
if nodeConfig.Node.BasedSequencer {
// Based sequencer mode - fetch transactions only from DA
if !nodeConfig.Node.Aggregator {
return nil, fmt.Errorf("based sequencer mode requires aggregator mode to be enabled")
}

basedSeq, err := based.NewBasedSequencer(daClient, nodeConfig, datastore, genesis, logger)
basedSeq, err := based.NewBasedSequencer(daClient, nodeConfig, datastore, genesis, logger, executor)
if err != nil {
return nil, fmt.Errorf("failed to create based sequencer: %w", err)
}
Expand All @@ -182,15 +183,12 @@ func createSequencer(
[]byte(genesis.ChainID),
1000,
genesis,
executor,
)
if err != nil {
return nil, fmt.Errorf("failed to create single sequencer: %w", err)
}

logger.Info().
Str("forced_inclusion_namespace", nodeConfig.DA.GetForcedInclusionNamespace()).
Msg("single sequencer initialized")

return sequencer, nil
}

Expand Down
6 changes: 3 additions & 3 deletions apps/evm/go.mod
Original file line number Diff line number Diff line change
Expand Up @@ -9,7 +9,7 @@ replace (
)

require (
github.com/celestiaorg/go-header v0.7.5-0.20260116211018-3f61d145c9d2
github.com/celestiaorg/go-header v0.8.0
github.com/ethereum/go-ethereum v1.16.8
github.com/evstack/ev-node v1.0.0-beta.10
github.com/evstack/ev-node/core v1.0.0-beta.5
Expand Down Expand Up @@ -37,7 +37,7 @@ require (
github.com/celestiaorg/nmt v0.24.2 // indirect
github.com/cenkalti/backoff/v5 v5.0.3 // indirect
github.com/cespare/xxhash/v2 v2.3.0 // indirect
github.com/consensys/gnark-crypto v0.18.0 // indirect
github.com/consensys/gnark-crypto v0.18.2 // indirect
github.com/crate-crypto/go-eth-kzg v1.4.0 // indirect
github.com/crate-crypto/go-ipa v0.0.0-20240724233137-53bbb0ceb27a // indirect
github.com/davecgh/go-spew v1.1.2-0.20180830191138-d8f796af33cc // indirect
Expand Down Expand Up @@ -100,7 +100,7 @@ require (
github.com/libp2p/go-flow-metrics v0.3.0 // indirect
github.com/libp2p/go-libp2p v0.46.0 // indirect
github.com/libp2p/go-libp2p-asn-util v0.4.1 // indirect
github.com/libp2p/go-libp2p-kad-dht v0.36.0 // indirect
github.com/libp2p/go-libp2p-kad-dht v0.37.0 // indirect
github.com/libp2p/go-libp2p-kbucket v0.8.0 // indirect
github.com/libp2p/go-libp2p-pubsub v0.15.0 // indirect
github.com/libp2p/go-libp2p-record v0.3.1 // indirect
Expand Down
12 changes: 6 additions & 6 deletions apps/evm/go.sum
Original file line number Diff line number Diff line change
Expand Up @@ -283,8 +283,8 @@ github.com/boltdb/bolt v1.3.1 h1:JQmyP4ZBrce+ZQu0dY660FMfatumYDLun9hBCUVIkF4=
github.com/boltdb/bolt v1.3.1/go.mod h1:clJnj/oiGkjum5o1McbSZDSLxVThjynRyGBgiAx27Ps=
github.com/boombuler/barcode v1.0.0/go.mod h1:paBWMcWSl3LHKBqUq+rly7CNSldXjb2rDl3JlRe0mD8=
github.com/boombuler/barcode v1.0.1/go.mod h1:paBWMcWSl3LHKBqUq+rly7CNSldXjb2rDl3JlRe0mD8=
github.com/celestiaorg/go-header v0.7.5-0.20260116211018-3f61d145c9d2 h1:jvRM1RT60oRy8jCneGYdX61Y8U2dI9uxjqT87H8uWq4=
github.com/celestiaorg/go-header v0.7.5-0.20260116211018-3f61d145c9d2/go.mod h1:X00prITrMa2kxgEX15WQnbLf0uV6tlvTesDKC5KsDVQ=
github.com/celestiaorg/go-header v0.8.0 h1:j9/t/uhxif26WQ3fULDAh3I55Fh3lJk6qMXPFFuOy28=
github.com/celestiaorg/go-header v0.8.0/go.mod h1:X00prITrMa2kxgEX15WQnbLf0uV6tlvTesDKC5KsDVQ=
github.com/celestiaorg/go-libp2p-messenger v0.2.2 h1:osoUfqjss7vWTIZrrDSy953RjQz+ps/vBFE7bychLEc=
github.com/celestiaorg/go-libp2p-messenger v0.2.2/go.mod h1:oTCRV5TfdO7V/k6nkx7QjQzGrWuJbupv+0o1cgnY2i4=
github.com/celestiaorg/go-square/merkle v0.0.0-20240627094109-7d01436067a3 h1:wP84mtwOCVNOTfS3zErICjxKLnh74Z1uf+tdrlSFjVM=
Expand Down Expand Up @@ -342,8 +342,8 @@ github.com/cockroachdb/redact v1.1.5 h1:u1PMllDkdFfPWaNGMyLD1+so+aq3uUItthCFqzwP
github.com/cockroachdb/redact v1.1.5/go.mod h1:BVNblN9mBWFyMyqK1k3AAiSxhvhfK2oOZZ2lK+dpvRg=
github.com/cockroachdb/tokenbucket v0.0.0-20230807174530-cc333fc44b06 h1:zuQyyAKVxetITBuuhv3BI9cMrmStnpT18zmgmTxunpo=
github.com/cockroachdb/tokenbucket v0.0.0-20230807174530-cc333fc44b06/go.mod h1:7nc4anLGjupUW/PeY5qiNYsdNXj7zopG+eqsS7To5IQ=
github.com/consensys/gnark-crypto v0.18.0 h1:vIye/FqI50VeAr0B3dx+YjeIvmc3LWz4yEfbWBpTUf0=
github.com/consensys/gnark-crypto v0.18.0/go.mod h1:L3mXGFTe1ZN+RSJ+CLjUt9x7PNdx8ubaYfDROyp2Z8c=
github.com/consensys/gnark-crypto v0.18.2 h1:+unEU7+M6vc9JszZPNTcRTwtrJg85tb57+5Gkyrz3hU=
github.com/consensys/gnark-crypto v0.18.2/go.mod h1:L3mXGFTe1ZN+RSJ+CLjUt9x7PNdx8ubaYfDROyp2Z8c=
github.com/coreos/go-systemd/v22 v22.5.0/go.mod h1:Y58oyj3AT4RCenI/lSvhwexgC+NSVTIJ3seZv2GcEnc=
github.com/cpuguy83/go-md2man/v2 v2.0.0-20190314233015-f79a8a8ca69d/go.mod h1:maD7wRr/U5Z6m/iR4s+kqSMx2CaBsrgA7czyZG/E6dU=
github.com/cpuguy83/go-md2man/v2 v2.0.6 h1:XJtiaUW6dEEqVuZiMTn1ldk455QWwEIsMIJlo5vtkx0=
Expand Down Expand Up @@ -746,8 +746,8 @@ github.com/libp2p/go-libp2p v0.46.0 h1:0T2yvIKpZ3DVYCuPOFxPD1layhRU486pj9rSlGWYn
github.com/libp2p/go-libp2p v0.46.0/go.mod h1:TbIDnpDjBLa7isdgYpbxozIVPBTmM/7qKOJP4SFySrQ=
github.com/libp2p/go-libp2p-asn-util v0.4.1 h1:xqL7++IKD9TBFMgnLPZR6/6iYhawHKHl950SO9L6n94=
github.com/libp2p/go-libp2p-asn-util v0.4.1/go.mod h1:d/NI6XZ9qxw67b4e+NgpQexCIiFYJjErASrYW4PFDN8=
github.com/libp2p/go-libp2p-kad-dht v0.36.0 h1:7QuXhV36+Vyj+L6A7mrYkn2sYLrbRcbjvsYDu/gXhn8=
github.com/libp2p/go-libp2p-kad-dht v0.36.0/go.mod h1:O24LxTH9Rt3I5XU8nmiA9VynS4TrTwAyj+zBJKB05vQ=
github.com/libp2p/go-libp2p-kad-dht v0.37.0 h1:V1IkFzK9taNS1UNAx260foulcBPH+watAUFjNo2qMUY=
github.com/libp2p/go-libp2p-kad-dht v0.37.0/go.mod h1:o4FPa1ea++UVAMJ1c+kyjUmj3CKm9+ZCyzQb4uutCFM=
github.com/libp2p/go-libp2p-kbucket v0.8.0 h1:QAK7RzKJpYe+EuSEATAaaHYMYLkPDGC18m9jxPLnU8s=
github.com/libp2p/go-libp2p-kbucket v0.8.0/go.mod h1:JMlxqcEyKwO6ox716eyC0hmiduSWZZl6JY93mGaaqc4=
github.com/libp2p/go-libp2p-pubsub v0.15.0 h1:cG7Cng2BT82WttmPFMi50gDNV+58K626m/wR00vGL1o=
Expand Down
10 changes: 4 additions & 6 deletions apps/grpc/cmd/run.go
Original file line number Diff line number Diff line change
Expand Up @@ -75,7 +75,7 @@ The execution client must implement the Evolve execution gRPC interface.`,
}

// Create sequencer based on configuration
sequencer, err := createSequencer(cmd.Context(), logger, datastore, nodeConfig, genesis)
sequencer, err := createSequencer(cmd.Context(), logger, datastore, nodeConfig, genesis, executor)
if err != nil {
return err
}
Expand Down Expand Up @@ -106,6 +106,7 @@ func createSequencer(
datastore datastore.Batching,
nodeConfig config.Config,
genesis genesis.Genesis,
executor execution.Executor,
) (coresequencer.Sequencer, error) {
blobClient, err := blobrpc.NewClient(ctx, nodeConfig.DA.Address, nodeConfig.DA.AuthToken, "")
if err != nil {
Expand All @@ -120,7 +121,7 @@ func createSequencer(
return nil, fmt.Errorf("based sequencer mode requires aggregator mode to be enabled")
}

basedSeq, err := based.NewBasedSequencer(daClient, nodeConfig, datastore, genesis, logger)
basedSeq, err := based.NewBasedSequencer(daClient, nodeConfig, datastore, genesis, logger, executor)
if err != nil {
return nil, fmt.Errorf("failed to create based sequencer: %w", err)
}
Expand All @@ -141,15 +142,12 @@ func createSequencer(
[]byte(genesis.ChainID),
1000,
genesis,
executor,
)
if err != nil {
return nil, fmt.Errorf("failed to create single sequencer: %w", err)
}

logger.Info().
Str("forced_inclusion_namespace", nodeConfig.DA.GetForcedInclusionNamespace()).
Msg("single sequencer initialized")

return sequencer, nil
}

Expand Down
4 changes: 2 additions & 2 deletions apps/grpc/go.mod
Original file line number Diff line number Diff line change
Expand Up @@ -24,7 +24,7 @@ require (
github.com/benbjohnson/clock v1.3.5 // indirect
github.com/beorn7/perks v1.0.1 // indirect
github.com/boltdb/bolt v1.3.1 // indirect
github.com/celestiaorg/go-header v0.7.5-0.20260116211018-3f61d145c9d2 // indirect
github.com/celestiaorg/go-header v0.8.0 // indirect
github.com/celestiaorg/go-libp2p-messenger v0.2.2 // indirect
github.com/celestiaorg/go-square/merkle v0.0.0-20240627094109-7d01436067a3 // indirect
github.com/celestiaorg/go-square/v3 v3.0.2 // indirect
Expand Down Expand Up @@ -80,7 +80,7 @@ require (
github.com/libp2p/go-flow-metrics v0.3.0 // indirect
github.com/libp2p/go-libp2p v0.46.0 // indirect
github.com/libp2p/go-libp2p-asn-util v0.4.1 // indirect
github.com/libp2p/go-libp2p-kad-dht v0.36.0 // indirect
github.com/libp2p/go-libp2p-kad-dht v0.37.0 // indirect
github.com/libp2p/go-libp2p-kbucket v0.8.0 // indirect
github.com/libp2p/go-libp2p-pubsub v0.15.0 // indirect
github.com/libp2p/go-libp2p-record v0.3.1 // indirect
Expand Down
8 changes: 4 additions & 4 deletions apps/grpc/go.sum
Original file line number Diff line number Diff line change
Expand Up @@ -271,8 +271,8 @@ github.com/boltdb/bolt v1.3.1 h1:JQmyP4ZBrce+ZQu0dY660FMfatumYDLun9hBCUVIkF4=
github.com/boltdb/bolt v1.3.1/go.mod h1:clJnj/oiGkjum5o1McbSZDSLxVThjynRyGBgiAx27Ps=
github.com/boombuler/barcode v1.0.0/go.mod h1:paBWMcWSl3LHKBqUq+rly7CNSldXjb2rDl3JlRe0mD8=
github.com/boombuler/barcode v1.0.1/go.mod h1:paBWMcWSl3LHKBqUq+rly7CNSldXjb2rDl3JlRe0mD8=
github.com/celestiaorg/go-header v0.7.5-0.20260116211018-3f61d145c9d2 h1:jvRM1RT60oRy8jCneGYdX61Y8U2dI9uxjqT87H8uWq4=
github.com/celestiaorg/go-header v0.7.5-0.20260116211018-3f61d145c9d2/go.mod h1:X00prITrMa2kxgEX15WQnbLf0uV6tlvTesDKC5KsDVQ=
github.com/celestiaorg/go-header v0.8.0 h1:j9/t/uhxif26WQ3fULDAh3I55Fh3lJk6qMXPFFuOy28=
github.com/celestiaorg/go-header v0.8.0/go.mod h1:X00prITrMa2kxgEX15WQnbLf0uV6tlvTesDKC5KsDVQ=
github.com/celestiaorg/go-libp2p-messenger v0.2.2 h1:osoUfqjss7vWTIZrrDSy953RjQz+ps/vBFE7bychLEc=
github.com/celestiaorg/go-libp2p-messenger v0.2.2/go.mod h1:oTCRV5TfdO7V/k6nkx7QjQzGrWuJbupv+0o1cgnY2i4=
github.com/celestiaorg/go-square/merkle v0.0.0-20240627094109-7d01436067a3 h1:wP84mtwOCVNOTfS3zErICjxKLnh74Z1uf+tdrlSFjVM=
Expand Down Expand Up @@ -676,8 +676,8 @@ github.com/libp2p/go-libp2p v0.46.0 h1:0T2yvIKpZ3DVYCuPOFxPD1layhRU486pj9rSlGWYn
github.com/libp2p/go-libp2p v0.46.0/go.mod h1:TbIDnpDjBLa7isdgYpbxozIVPBTmM/7qKOJP4SFySrQ=
github.com/libp2p/go-libp2p-asn-util v0.4.1 h1:xqL7++IKD9TBFMgnLPZR6/6iYhawHKHl950SO9L6n94=
github.com/libp2p/go-libp2p-asn-util v0.4.1/go.mod h1:d/NI6XZ9qxw67b4e+NgpQexCIiFYJjErASrYW4PFDN8=
github.com/libp2p/go-libp2p-kad-dht v0.36.0 h1:7QuXhV36+Vyj+L6A7mrYkn2sYLrbRcbjvsYDu/gXhn8=
github.com/libp2p/go-libp2p-kad-dht v0.36.0/go.mod h1:O24LxTH9Rt3I5XU8nmiA9VynS4TrTwAyj+zBJKB05vQ=
github.com/libp2p/go-libp2p-kad-dht v0.37.0 h1:V1IkFzK9taNS1UNAx260foulcBPH+watAUFjNo2qMUY=
github.com/libp2p/go-libp2p-kad-dht v0.37.0/go.mod h1:o4FPa1ea++UVAMJ1c+kyjUmj3CKm9+ZCyzQb4uutCFM=
github.com/libp2p/go-libp2p-kbucket v0.8.0 h1:QAK7RzKJpYe+EuSEATAaaHYMYLkPDGC18m9jxPLnU8s=
github.com/libp2p/go-libp2p-kbucket v0.8.0/go.mod h1:JMlxqcEyKwO6ox716eyC0hmiduSWZZl6JY93mGaaqc4=
github.com/libp2p/go-libp2p-pubsub v0.15.0 h1:cG7Cng2BT82WttmPFMi50gDNV+58K626m/wR00vGL1o=
Expand Down
11 changes: 5 additions & 6 deletions apps/testapp/cmd/run.go
Original file line number Diff line number Diff line change
Expand Up @@ -11,6 +11,7 @@ import (

kvexecutor "github.com/evstack/ev-node/apps/testapp/kv"
"github.com/evstack/ev-node/block"
"github.com/evstack/ev-node/core/execution"
coresequencer "github.com/evstack/ev-node/core/sequencer"
"github.com/evstack/ev-node/node"
"github.com/evstack/ev-node/pkg/cmd"
Expand Down Expand Up @@ -90,7 +91,7 @@ var RunCmd = &cobra.Command{
}

// Create sequencer based on configuration
sequencer, err := createSequencer(ctx, logger, datastore, nodeConfig, genesis)
sequencer, err := createSequencer(ctx, logger, datastore, nodeConfig, genesis, executor)
if err != nil {
return err
}
Expand All @@ -108,6 +109,7 @@ func createSequencer(
datastore datastore.Batching,
nodeConfig config.Config,
genesis genesis.Genesis,
executor execution.Executor,
) (coresequencer.Sequencer, error) {
blobClient, err := blobrpc.NewClient(ctx, nodeConfig.DA.Address, nodeConfig.DA.AuthToken, "")
if err != nil {
Expand All @@ -122,7 +124,7 @@ func createSequencer(
return nil, fmt.Errorf("based sequencer mode requires aggregator mode to be enabled")
}

basedSeq, err := based.NewBasedSequencer(daClient, nodeConfig, datastore, genesis, logger)
basedSeq, err := based.NewBasedSequencer(daClient, nodeConfig, datastore, genesis, logger, executor)
if err != nil {
return nil, fmt.Errorf("failed to create based sequencer: %w", err)
}
Expand All @@ -143,14 +145,11 @@ func createSequencer(
[]byte(genesis.ChainID),
1000,
genesis,
executor,
)
if err != nil {
return nil, fmt.Errorf("failed to create single sequencer: %w", err)
}

logger.Info().
Str("forced_inclusion_namespace", nodeConfig.DA.GetForcedInclusionNamespace()).
Msg("single sequencer initialized")

return sequencer, nil
}
4 changes: 2 additions & 2 deletions apps/testapp/go.mod
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,7 @@ replace (
)

require (
github.com/celestiaorg/go-header v0.7.5-0.20260116211018-3f61d145c9d2
github.com/celestiaorg/go-header v0.8.0
github.com/evstack/ev-node v1.0.0-beta.10
github.com/evstack/ev-node/core v1.0.0-beta.5
github.com/ipfs/go-datastore v0.9.0
Expand Down Expand Up @@ -79,7 +79,7 @@ require (
github.com/libp2p/go-flow-metrics v0.3.0 // indirect
github.com/libp2p/go-libp2p v0.46.0 // indirect
github.com/libp2p/go-libp2p-asn-util v0.4.1 // indirect
github.com/libp2p/go-libp2p-kad-dht v0.36.0 // indirect
github.com/libp2p/go-libp2p-kad-dht v0.37.0 // indirect
github.com/libp2p/go-libp2p-kbucket v0.8.0 // indirect
github.com/libp2p/go-libp2p-pubsub v0.15.0 // indirect
github.com/libp2p/go-libp2p-record v0.3.1 // indirect
Expand Down
8 changes: 4 additions & 4 deletions apps/testapp/go.sum
Original file line number Diff line number Diff line change
Expand Up @@ -271,8 +271,8 @@ github.com/boltdb/bolt v1.3.1 h1:JQmyP4ZBrce+ZQu0dY660FMfatumYDLun9hBCUVIkF4=
github.com/boltdb/bolt v1.3.1/go.mod h1:clJnj/oiGkjum5o1McbSZDSLxVThjynRyGBgiAx27Ps=
github.com/boombuler/barcode v1.0.0/go.mod h1:paBWMcWSl3LHKBqUq+rly7CNSldXjb2rDl3JlRe0mD8=
github.com/boombuler/barcode v1.0.1/go.mod h1:paBWMcWSl3LHKBqUq+rly7CNSldXjb2rDl3JlRe0mD8=
github.com/celestiaorg/go-header v0.7.5-0.20260116211018-3f61d145c9d2 h1:jvRM1RT60oRy8jCneGYdX61Y8U2dI9uxjqT87H8uWq4=
github.com/celestiaorg/go-header v0.7.5-0.20260116211018-3f61d145c9d2/go.mod h1:X00prITrMa2kxgEX15WQnbLf0uV6tlvTesDKC5KsDVQ=
github.com/celestiaorg/go-header v0.8.0 h1:j9/t/uhxif26WQ3fULDAh3I55Fh3lJk6qMXPFFuOy28=
github.com/celestiaorg/go-header v0.8.0/go.mod h1:X00prITrMa2kxgEX15WQnbLf0uV6tlvTesDKC5KsDVQ=
github.com/celestiaorg/go-libp2p-messenger v0.2.2 h1:osoUfqjss7vWTIZrrDSy953RjQz+ps/vBFE7bychLEc=
github.com/celestiaorg/go-libp2p-messenger v0.2.2/go.mod h1:oTCRV5TfdO7V/k6nkx7QjQzGrWuJbupv+0o1cgnY2i4=
github.com/celestiaorg/go-square/merkle v0.0.0-20240627094109-7d01436067a3 h1:wP84mtwOCVNOTfS3zErICjxKLnh74Z1uf+tdrlSFjVM=
Expand Down Expand Up @@ -676,8 +676,8 @@ github.com/libp2p/go-libp2p v0.46.0 h1:0T2yvIKpZ3DVYCuPOFxPD1layhRU486pj9rSlGWYn
github.com/libp2p/go-libp2p v0.46.0/go.mod h1:TbIDnpDjBLa7isdgYpbxozIVPBTmM/7qKOJP4SFySrQ=
github.com/libp2p/go-libp2p-asn-util v0.4.1 h1:xqL7++IKD9TBFMgnLPZR6/6iYhawHKHl950SO9L6n94=
github.com/libp2p/go-libp2p-asn-util v0.4.1/go.mod h1:d/NI6XZ9qxw67b4e+NgpQexCIiFYJjErASrYW4PFDN8=
github.com/libp2p/go-libp2p-kad-dht v0.36.0 h1:7QuXhV36+Vyj+L6A7mrYkn2sYLrbRcbjvsYDu/gXhn8=
github.com/libp2p/go-libp2p-kad-dht v0.36.0/go.mod h1:O24LxTH9Rt3I5XU8nmiA9VynS4TrTwAyj+zBJKB05vQ=
github.com/libp2p/go-libp2p-kad-dht v0.37.0 h1:V1IkFzK9taNS1UNAx260foulcBPH+watAUFjNo2qMUY=
github.com/libp2p/go-libp2p-kad-dht v0.37.0/go.mod h1:o4FPa1ea++UVAMJ1c+kyjUmj3CKm9+ZCyzQb4uutCFM=
github.com/libp2p/go-libp2p-kbucket v0.8.0 h1:QAK7RzKJpYe+EuSEATAaaHYMYLkPDGC18m9jxPLnU8s=
github.com/libp2p/go-libp2p-kbucket v0.8.0/go.mod h1:JMlxqcEyKwO6ox716eyC0hmiduSWZZl6JY93mGaaqc4=
github.com/libp2p/go-libp2p-pubsub v0.15.0 h1:cG7Cng2BT82WttmPFMi50gDNV+58K626m/wR00vGL1o=
Expand Down
6 changes: 3 additions & 3 deletions apps/testapp/kv/http_server_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -141,7 +141,7 @@ func TestHandleKV_Get(t *testing.T) {
// Create and execute the transaction directly
tx := []byte(fmt.Sprintf("%s=%s", tt.key, tt.value))
ctx := context.Background()
_, _, err := exec.ExecuteTxs(ctx, [][]byte{tx}, 1, time.Now(), []byte(""))
_, err := exec.ExecuteTxs(ctx, [][]byte{tx}, 1, time.Now(), []byte(""))
if err != nil {
t.Fatalf("Failed to execute setup transaction: %v", err)
}
Expand Down Expand Up @@ -287,13 +287,13 @@ func TestHTTPIntegration_GetKVWithMultipleHeights(t *testing.T) {

// Execute transactions at different heights for the same key
txsHeight1 := [][]byte{[]byte("testkey=original_value")}
_, _, err = exec.ExecuteTxs(ctx, txsHeight1, 1, time.Now(), []byte(""))
_, err = exec.ExecuteTxs(ctx, txsHeight1, 1, time.Now(), []byte(""))
if err != nil {
t.Fatalf("ExecuteTxs failed for height 1: %v", err)
}

txsHeight2 := [][]byte{[]byte("testkey=updated_value")}
_, _, err = exec.ExecuteTxs(ctx, txsHeight2, 2, time.Now(), []byte(""))
_, err = exec.ExecuteTxs(ctx, txsHeight2, 2, time.Now(), []byte(""))
if err != nil {
t.Fatalf("ExecuteTxs failed for height 2: %v", err)
}
Expand Down
Loading
Loading
You are viewing a condensed version of this merge commit. You can view the full changes here.