mirror of
https://github.com/hl-archive-node/nanoreth.git
synced 2025-12-06 10:59:55 +00:00
Compare commits
18 Commits
nb-2025090
...
db10c23c56
| Author | SHA1 | Date | |
|---|---|---|---|
| db10c23c56 | |||
| fc395123f3 | |||
| 84ea1af682 | |||
| bd3e0626ed | |||
| 7d223a464e | |||
| afcc551f67 | |||
| 0dfd7a4c7f | |||
| 8faac526b7 | |||
| acfabf969c | |||
| fccf877a3a | |||
| 9e3f0c722e | |||
| cd5bcc4cb0 | |||
| d831a459bb | |||
| 66c2ee654c | |||
| 701e6a25e6 | |||
| ab11ce513f | |||
| 37b852e810 | |||
| 51c43d6dbd |
127
.github/ISSUE_TEMPLATE/bug.yml
vendored
Normal file
127
.github/ISSUE_TEMPLATE/bug.yml
vendored
Normal file
@ -0,0 +1,127 @@
|
||||
name: Bug Report
|
||||
description: Create a bug report
|
||||
labels: ["C-bug", "S-needs-triage"]
|
||||
body:
|
||||
- type: markdown
|
||||
attributes:
|
||||
value: |
|
||||
Thanks for taking the time to fill out this bug report! Please provide as much detail as possible.
|
||||
|
||||
If you believe you have found a vulnerability, please provide details [here](mailto:georgios@paradigm.xyz) instead.
|
||||
- type: textarea
|
||||
id: what-happened
|
||||
attributes:
|
||||
label: Describe the bug
|
||||
description: |
|
||||
A clear and concise description of what the bug is.
|
||||
|
||||
If the bug is in a crate you are using (i.e. you are not running the standard `reth` binary) please mention that as well.
|
||||
validations:
|
||||
required: true
|
||||
- type: textarea
|
||||
id: reproduction-steps
|
||||
attributes:
|
||||
label: Steps to reproduce
|
||||
description: Please provide any steps you think might be relevant to reproduce the bug.
|
||||
placeholder: |
|
||||
Steps to reproduce:
|
||||
|
||||
1. Start '...'
|
||||
2. Then '...'
|
||||
3. Check '...'
|
||||
4. See error
|
||||
validations:
|
||||
required: true
|
||||
- type: textarea
|
||||
id: logs
|
||||
attributes:
|
||||
label: Node logs
|
||||
description: |
|
||||
If applicable, please provide the node logs leading up to the bug.
|
||||
|
||||
**Please also provide debug logs.** By default, these can be found in:
|
||||
|
||||
- `~/.cache/reth/logs` on Linux
|
||||
- `~/Library/Caches/reth/logs` on macOS
|
||||
- `%localAppData%/reth/logs` on Windows
|
||||
render: text
|
||||
validations:
|
||||
required: false
|
||||
- type: dropdown
|
||||
id: platform
|
||||
attributes:
|
||||
label: Platform(s)
|
||||
description: What platform(s) did this occur on?
|
||||
multiple: true
|
||||
options:
|
||||
- Linux (x86)
|
||||
- Linux (ARM)
|
||||
- Mac (Intel)
|
||||
- Mac (Apple Silicon)
|
||||
- Windows (x86)
|
||||
- Windows (ARM)
|
||||
- type: dropdown
|
||||
id: container_type
|
||||
attributes:
|
||||
label: Container Type
|
||||
description: Were you running it in a container?
|
||||
multiple: true
|
||||
options:
|
||||
- Not running in a container
|
||||
- Docker
|
||||
- Kubernetes
|
||||
- LXC/LXD
|
||||
- Other
|
||||
validations:
|
||||
required: true
|
||||
- type: textarea
|
||||
id: client-version
|
||||
attributes:
|
||||
label: What version/commit are you on?
|
||||
description: This can be obtained with `reth --version`
|
||||
validations:
|
||||
required: true
|
||||
- type: textarea
|
||||
id: database-version
|
||||
attributes:
|
||||
label: What database version are you on?
|
||||
description: This can be obtained with `reth db version`
|
||||
validations:
|
||||
required: true
|
||||
- type: textarea
|
||||
id: network
|
||||
attributes:
|
||||
label: Which chain / network are you on?
|
||||
description: This is the argument you pass to `reth --chain`. If you are using `--dev`, type in 'dev' here. If you are not running with `--chain` or `--dev` then it is mainnet.
|
||||
validations:
|
||||
required: true
|
||||
- type: dropdown
|
||||
id: node-type
|
||||
attributes:
|
||||
label: What type of node are you running?
|
||||
options:
|
||||
- Archive (default)
|
||||
- Full via --full flag
|
||||
- Pruned with custom reth.toml config
|
||||
validations:
|
||||
required: true
|
||||
- type: textarea
|
||||
id: prune-config
|
||||
attributes:
|
||||
label: What prune config do you use, if any?
|
||||
description: The `[prune]` section in `reth.toml` file
|
||||
validations:
|
||||
required: false
|
||||
- type: input
|
||||
attributes:
|
||||
label: If you've built Reth from source, provide the full command you used
|
||||
validations:
|
||||
required: false
|
||||
- type: checkboxes
|
||||
id: terms
|
||||
attributes:
|
||||
label: Code of Conduct
|
||||
description: By submitting this issue, you agree to follow our [Code of Conduct](https://github.com/paradigmxyz/reth/blob/main/CONTRIBUTING.md#code-of-conduct)
|
||||
options:
|
||||
- label: I agree to follow the Code of Conduct
|
||||
required: true
|
||||
5
.github/ISSUE_TEMPLATE/config.yml
vendored
Normal file
5
.github/ISSUE_TEMPLATE/config.yml
vendored
Normal file
@ -0,0 +1,5 @@
|
||||
blank_issues_enabled: false
|
||||
contact_links:
|
||||
- name: GitHub Discussions
|
||||
url: https://github.com/paradigmxyz/reth/discussions
|
||||
about: Please ask and answer questions here to keep the issue tracker clean.
|
||||
19
.github/ISSUE_TEMPLATE/docs.yml
vendored
Normal file
19
.github/ISSUE_TEMPLATE/docs.yml
vendored
Normal file
@ -0,0 +1,19 @@
|
||||
name: Documentation
|
||||
description: Suggest a change to our documentation
|
||||
labels: ["C-docs", "S-needs-triage"]
|
||||
body:
|
||||
- type: markdown
|
||||
attributes:
|
||||
value: |
|
||||
If you are unsure if the docs are relevant or needed, please open up a discussion first.
|
||||
- type: textarea
|
||||
attributes:
|
||||
label: Describe the change
|
||||
description: |
|
||||
Please describe the documentation you want to change or add, and if it is for end-users or contributors.
|
||||
validations:
|
||||
required: true
|
||||
- type: textarea
|
||||
attributes:
|
||||
label: Additional context
|
||||
description: Add any other context to the feature (like screenshots, resources)
|
||||
21
.github/ISSUE_TEMPLATE/feature.yml
vendored
Normal file
21
.github/ISSUE_TEMPLATE/feature.yml
vendored
Normal file
@ -0,0 +1,21 @@
|
||||
name: Feature request
|
||||
description: Suggest a feature
|
||||
labels: ["C-enhancement", "S-needs-triage"]
|
||||
body:
|
||||
- type: markdown
|
||||
attributes:
|
||||
value: |
|
||||
Please ensure that the feature has not already been requested in the issue tracker.
|
||||
- type: textarea
|
||||
attributes:
|
||||
label: Describe the feature
|
||||
description: |
|
||||
Please describe the feature and what it is aiming to solve, if relevant.
|
||||
|
||||
If the feature is for a crate, please include a proposed API surface.
|
||||
validations:
|
||||
required: true
|
||||
- type: textarea
|
||||
attributes:
|
||||
label: Additional context
|
||||
description: Add any other context to the feature (like screenshots, resources)
|
||||
38
.github/workflows/docker.yml
vendored
Normal file
38
.github/workflows/docker.yml
vendored
Normal file
@ -0,0 +1,38 @@
|
||||
# Publishes the Docker image.
|
||||
|
||||
name: docker
|
||||
|
||||
on:
|
||||
push:
|
||||
tags:
|
||||
- v*
|
||||
- nb-*
|
||||
|
||||
env:
|
||||
IMAGE_NAME: ${{ github.repository_owner }}/nanoreth
|
||||
CARGO_TERM_COLOR: always
|
||||
DOCKER_IMAGE_NAME: ghcr.io/${{ github.repository_owner }}/nanoreth
|
||||
DOCKER_USERNAME: ${{ github.actor }}
|
||||
|
||||
jobs:
|
||||
build:
|
||||
name: build and push as latest
|
||||
runs-on: ubuntu-24.04
|
||||
permissions:
|
||||
packages: write
|
||||
contents: read
|
||||
steps:
|
||||
- uses: actions/checkout@v5
|
||||
- uses: rui314/setup-mold@v1
|
||||
- uses: dtolnay/rust-toolchain@stable
|
||||
- uses: Swatinem/rust-cache@v2
|
||||
with:
|
||||
cache-on-failure: true
|
||||
- name: Log in to Docker
|
||||
run: |
|
||||
echo "${{ secrets.GITHUB_TOKEN }}" | docker login ghcr.io --username ${DOCKER_USERNAME} --password-stdin
|
||||
- name: Set up Docker builder
|
||||
run: |
|
||||
docker buildx create --use --name builder
|
||||
- name: Build and push nanoreth image
|
||||
run: make IMAGE_NAME=$IMAGE_NAME DOCKER_IMAGE_NAME=$DOCKER_IMAGE_NAME PROFILE=maxperf docker-build-push-latest
|
||||
776
Cargo.lock
generated
776
Cargo.lock
generated
File diff suppressed because it is too large
Load Diff
108
Cargo.toml
108
Cargo.toml
@ -2,6 +2,7 @@
|
||||
name = "reth_hl"
|
||||
version = "0.1.0"
|
||||
edition = "2021"
|
||||
build = "build.rs"
|
||||
|
||||
[lib]
|
||||
name = "reth_hl"
|
||||
@ -25,67 +26,68 @@ lto = "fat"
|
||||
codegen-units = 1
|
||||
|
||||
[dependencies]
|
||||
reth = { git = "https://github.com/sprites0/reth", rev = "a690ef25b56039195e7e4a4abd01c78aedcc73fb" }
|
||||
reth-cli = { git = "https://github.com/sprites0/reth", rev = "a690ef25b56039195e7e4a4abd01c78aedcc73fb" }
|
||||
reth-cli-commands = { git = "https://github.com/sprites0/reth", rev = "a690ef25b56039195e7e4a4abd01c78aedcc73fb" }
|
||||
reth-basic-payload-builder = { git = "https://github.com/sprites0/reth", rev = "a690ef25b56039195e7e4a4abd01c78aedcc73fb" }
|
||||
reth-db = { git = "https://github.com/sprites0/reth", rev = "a690ef25b56039195e7e4a4abd01c78aedcc73fb" }
|
||||
reth-db-api = { git = "https://github.com/sprites0/reth", rev = "a690ef25b56039195e7e4a4abd01c78aedcc73fb" }
|
||||
reth-chainspec = { git = "https://github.com/sprites0/reth", rev = "a690ef25b56039195e7e4a4abd01c78aedcc73fb" }
|
||||
reth-cli-util = { git = "https://github.com/sprites0/reth", rev = "a690ef25b56039195e7e4a4abd01c78aedcc73fb" }
|
||||
reth-discv4 = { git = "https://github.com/sprites0/reth", rev = "a690ef25b56039195e7e4a4abd01c78aedcc73fb" }
|
||||
reth-engine-primitives = { git = "https://github.com/sprites0/reth", rev = "a690ef25b56039195e7e4a4abd01c78aedcc73fb" }
|
||||
reth-ethereum-forks = { git = "https://github.com/sprites0/reth", rev = "a690ef25b56039195e7e4a4abd01c78aedcc73fb" }
|
||||
reth-ethereum-payload-builder = { git = "https://github.com/sprites0/reth", rev = "a690ef25b56039195e7e4a4abd01c78aedcc73fb" }
|
||||
reth-ethereum-primitives = { git = "https://github.com/sprites0/reth", rev = "a690ef25b56039195e7e4a4abd01c78aedcc73fb" }
|
||||
reth-eth-wire = { git = "https://github.com/sprites0/reth", rev = "a690ef25b56039195e7e4a4abd01c78aedcc73fb" }
|
||||
reth-eth-wire-types = { git = "https://github.com/sprites0/reth", rev = "a690ef25b56039195e7e4a4abd01c78aedcc73fb" }
|
||||
reth-evm = { git = "https://github.com/sprites0/reth", rev = "a690ef25b56039195e7e4a4abd01c78aedcc73fb" }
|
||||
reth-evm-ethereum = { git = "https://github.com/sprites0/reth", rev = "a690ef25b56039195e7e4a4abd01c78aedcc73fb" }
|
||||
reth-node-core = { git = "https://github.com/sprites0/reth", rev = "a690ef25b56039195e7e4a4abd01c78aedcc73fb" }
|
||||
reth-revm = { git = "https://github.com/sprites0/reth", rev = "a690ef25b56039195e7e4a4abd01c78aedcc73fb" }
|
||||
reth-network = { git = "https://github.com/sprites0/reth", rev = "a690ef25b56039195e7e4a4abd01c78aedcc73fb" }
|
||||
reth-network-p2p = { git = "https://github.com/sprites0/reth", rev = "a690ef25b56039195e7e4a4abd01c78aedcc73fb" }
|
||||
reth-network-api = { git = "https://github.com/sprites0/reth", rev = "a690ef25b56039195e7e4a4abd01c78aedcc73fb" }
|
||||
reth-node-ethereum = { git = "https://github.com/sprites0/reth", rev = "a690ef25b56039195e7e4a4abd01c78aedcc73fb" }
|
||||
reth-network-peers = { git = "https://github.com/sprites0/reth", rev = "a690ef25b56039195e7e4a4abd01c78aedcc73fb" }
|
||||
reth-payload-primitives = { git = "https://github.com/sprites0/reth", rev = "a690ef25b56039195e7e4a4abd01c78aedcc73fb" }
|
||||
reth-primitives = { git = "https://github.com/sprites0/reth", rev = "a690ef25b56039195e7e4a4abd01c78aedcc73fb" }
|
||||
reth-primitives-traits = { git = "https://github.com/sprites0/reth", rev = "a690ef25b56039195e7e4a4abd01c78aedcc73fb" }
|
||||
reth-provider = { git = "https://github.com/sprites0/reth", rev = "a690ef25b56039195e7e4a4abd01c78aedcc73fb", features = ["test-utils"] }
|
||||
reth-rpc = { git = "https://github.com/sprites0/reth", rev = "a690ef25b56039195e7e4a4abd01c78aedcc73fb" }
|
||||
reth-rpc-eth-api = { git = "https://github.com/sprites0/reth", rev = "a690ef25b56039195e7e4a4abd01c78aedcc73fb" }
|
||||
reth-rpc-engine-api = { git = "https://github.com/sprites0/reth", rev = "a690ef25b56039195e7e4a4abd01c78aedcc73fb" }
|
||||
reth-tracing = { git = "https://github.com/sprites0/reth", rev = "a690ef25b56039195e7e4a4abd01c78aedcc73fb" }
|
||||
reth-trie-common = { git = "https://github.com/sprites0/reth", rev = "a690ef25b56039195e7e4a4abd01c78aedcc73fb" }
|
||||
reth-trie-db = { git = "https://github.com/sprites0/reth", rev = "a690ef25b56039195e7e4a4abd01c78aedcc73fb" }
|
||||
reth-codecs = { git = "https://github.com/sprites0/reth", rev = "a690ef25b56039195e7e4a4abd01c78aedcc73fb" }
|
||||
reth-transaction-pool = { git = "https://github.com/sprites0/reth", rev = "a690ef25b56039195e7e4a4abd01c78aedcc73fb" }
|
||||
reth-stages-types = { git = "https://github.com/sprites0/reth", rev = "a690ef25b56039195e7e4a4abd01c78aedcc73fb" }
|
||||
revm = { version = "28.0.1", default-features = false }
|
||||
reth = { git = "https://github.com/sprites0/reth", rev = "d26fd2e25b57d695aa453c93f15a8cd158a1f505" }
|
||||
reth-cli = { git = "https://github.com/sprites0/reth", rev = "d26fd2e25b57d695aa453c93f15a8cd158a1f505" }
|
||||
reth-cli-commands = { git = "https://github.com/sprites0/reth", rev = "d26fd2e25b57d695aa453c93f15a8cd158a1f505" }
|
||||
reth-basic-payload-builder = { git = "https://github.com/sprites0/reth", rev = "d26fd2e25b57d695aa453c93f15a8cd158a1f505" }
|
||||
reth-db = { git = "https://github.com/sprites0/reth", rev = "d26fd2e25b57d695aa453c93f15a8cd158a1f505" }
|
||||
reth-db-api = { git = "https://github.com/sprites0/reth", rev = "d26fd2e25b57d695aa453c93f15a8cd158a1f505" }
|
||||
reth-chainspec = { git = "https://github.com/sprites0/reth", rev = "d26fd2e25b57d695aa453c93f15a8cd158a1f505" }
|
||||
reth-cli-util = { git = "https://github.com/sprites0/reth", rev = "d26fd2e25b57d695aa453c93f15a8cd158a1f505" }
|
||||
reth-discv4 = { git = "https://github.com/sprites0/reth", rev = "d26fd2e25b57d695aa453c93f15a8cd158a1f505" }
|
||||
reth-engine-primitives = { git = "https://github.com/sprites0/reth", rev = "d26fd2e25b57d695aa453c93f15a8cd158a1f505" }
|
||||
reth-ethereum-forks = { git = "https://github.com/sprites0/reth", rev = "d26fd2e25b57d695aa453c93f15a8cd158a1f505" }
|
||||
reth-ethereum-payload-builder = { git = "https://github.com/sprites0/reth", rev = "d26fd2e25b57d695aa453c93f15a8cd158a1f505" }
|
||||
reth-ethereum-primitives = { git = "https://github.com/sprites0/reth", rev = "d26fd2e25b57d695aa453c93f15a8cd158a1f505" }
|
||||
reth-eth-wire = { git = "https://github.com/sprites0/reth", rev = "d26fd2e25b57d695aa453c93f15a8cd158a1f505" }
|
||||
reth-eth-wire-types = { git = "https://github.com/sprites0/reth", rev = "d26fd2e25b57d695aa453c93f15a8cd158a1f505" }
|
||||
reth-evm = { git = "https://github.com/sprites0/reth", rev = "d26fd2e25b57d695aa453c93f15a8cd158a1f505" }
|
||||
reth-evm-ethereum = { git = "https://github.com/sprites0/reth", rev = "d26fd2e25b57d695aa453c93f15a8cd158a1f505" }
|
||||
reth-node-core = { git = "https://github.com/sprites0/reth", rev = "d26fd2e25b57d695aa453c93f15a8cd158a1f505" }
|
||||
reth-revm = { git = "https://github.com/sprites0/reth", rev = "d26fd2e25b57d695aa453c93f15a8cd158a1f505" }
|
||||
reth-network = { git = "https://github.com/sprites0/reth", rev = "d26fd2e25b57d695aa453c93f15a8cd158a1f505" }
|
||||
reth-network-p2p = { git = "https://github.com/sprites0/reth", rev = "d26fd2e25b57d695aa453c93f15a8cd158a1f505" }
|
||||
reth-network-api = { git = "https://github.com/sprites0/reth", rev = "d26fd2e25b57d695aa453c93f15a8cd158a1f505" }
|
||||
reth-node-ethereum = { git = "https://github.com/sprites0/reth", rev = "d26fd2e25b57d695aa453c93f15a8cd158a1f505" }
|
||||
reth-network-peers = { git = "https://github.com/sprites0/reth", rev = "d26fd2e25b57d695aa453c93f15a8cd158a1f505" }
|
||||
reth-payload-primitives = { git = "https://github.com/sprites0/reth", rev = "d26fd2e25b57d695aa453c93f15a8cd158a1f505" }
|
||||
reth-primitives = { git = "https://github.com/sprites0/reth", rev = "d26fd2e25b57d695aa453c93f15a8cd158a1f505" }
|
||||
reth-primitives-traits = { git = "https://github.com/sprites0/reth", rev = "d26fd2e25b57d695aa453c93f15a8cd158a1f505" }
|
||||
reth-provider = { git = "https://github.com/sprites0/reth", rev = "d26fd2e25b57d695aa453c93f15a8cd158a1f505", features = ["test-utils"] }
|
||||
reth-rpc = { git = "https://github.com/sprites0/reth", rev = "d26fd2e25b57d695aa453c93f15a8cd158a1f505" }
|
||||
reth-rpc-eth-api = { git = "https://github.com/sprites0/reth", rev = "d26fd2e25b57d695aa453c93f15a8cd158a1f505" }
|
||||
reth-rpc-engine-api = { git = "https://github.com/sprites0/reth", rev = "d26fd2e25b57d695aa453c93f15a8cd158a1f505" }
|
||||
reth-tracing = { git = "https://github.com/sprites0/reth", rev = "d26fd2e25b57d695aa453c93f15a8cd158a1f505" }
|
||||
reth-trie-common = { git = "https://github.com/sprites0/reth", rev = "d26fd2e25b57d695aa453c93f15a8cd158a1f505" }
|
||||
reth-trie-db = { git = "https://github.com/sprites0/reth", rev = "d26fd2e25b57d695aa453c93f15a8cd158a1f505" }
|
||||
reth-codecs = { git = "https://github.com/sprites0/reth", rev = "d26fd2e25b57d695aa453c93f15a8cd158a1f505" }
|
||||
reth-transaction-pool = { git = "https://github.com/sprites0/reth", rev = "d26fd2e25b57d695aa453c93f15a8cd158a1f505" }
|
||||
reth-stages-types = { git = "https://github.com/sprites0/reth", rev = "d26fd2e25b57d695aa453c93f15a8cd158a1f505" }
|
||||
reth-metrics = { git = "https://github.com/sprites0/reth", rev = "d26fd2e25b57d695aa453c93f15a8cd158a1f505" }
|
||||
revm = { version = "29.0.0", default-features = false }
|
||||
|
||||
# alloy dependencies
|
||||
alloy-genesis = { version = "1.0.23", default-features = false }
|
||||
alloy-consensus = { version = "1.0.23", default-features = false }
|
||||
alloy-genesis = { version = "1.0.30", default-features = false }
|
||||
alloy-consensus = { version = "1.0.30", default-features = false }
|
||||
alloy-chains = { version = "0.2.5", default-features = false }
|
||||
alloy-eips = { version = "1.0.23", default-features = false }
|
||||
alloy-evm = { version = "0.18.2", default-features = false }
|
||||
alloy-eips = { version = "1.0.30", default-features = false }
|
||||
alloy-evm = { version = "0.20.1", default-features = false }
|
||||
alloy-json-abi = { version = "1.3.1", default-features = false }
|
||||
alloy-json-rpc = { version = "1.0.23", default-features = false }
|
||||
alloy-json-rpc = { version = "1.0.30", default-features = false }
|
||||
alloy-dyn-abi = "1.3.1"
|
||||
alloy-network = { version = "1.0.23", default-features = false }
|
||||
alloy-network = { version = "1.0.30", default-features = false }
|
||||
alloy-primitives = { version = "1.3.1", default-features = false, features = ["map-foldhash"] }
|
||||
alloy-rlp = { version = "0.3.10", default-features = false, features = ["core-net"] }
|
||||
alloy-rpc-types = { version = "1.0.23", features = ["eth"], default-features = false }
|
||||
alloy-rpc-types-eth = { version = "1.0.23", default-features = false }
|
||||
alloy-rpc-types-engine = { version = "1.0.23", default-features = false }
|
||||
alloy-signer = { version = "1.0.23", default-features = false }
|
||||
alloy-rpc-types = { version = "1.0.30", features = ["eth"], default-features = false }
|
||||
alloy-rpc-types-eth = { version = "1.0.30", default-features = false }
|
||||
alloy-rpc-types-engine = { version = "1.0.30", default-features = false }
|
||||
alloy-signer = { version = "1.0.30", default-features = false }
|
||||
alloy-sol-macro = "1.3.1"
|
||||
alloy-sol-types = { version = "1.3.1", default-features = false }
|
||||
|
||||
jsonrpsee = "0.25.1"
|
||||
jsonrpsee-core = "0.25.1"
|
||||
jsonrpsee-types = "0.25.1"
|
||||
jsonrpsee = "0.26.0"
|
||||
jsonrpsee-core = "0.26.0"
|
||||
jsonrpsee-types = "0.26.0"
|
||||
|
||||
# misc dependencies
|
||||
auto_impl = "1"
|
||||
@ -166,3 +168,7 @@ client = [
|
||||
|
||||
[dev-dependencies]
|
||||
tempfile = "3.20.0"
|
||||
|
||||
[build-dependencies]
|
||||
vergen = { version = "9.0.4", features = ["build", "cargo", "emit_and_set"] }
|
||||
vergen-git2 = "1.0.5"
|
||||
51
Makefile
51
Makefile
@ -1,6 +1,8 @@
|
||||
# Modifed from reth Makefile
|
||||
.DEFAULT_GOAL := help
|
||||
|
||||
GIT_SHA ?= $(shell git rev-parse HEAD)
|
||||
GIT_TAG ?= $(shell git describe --tags --abbrev=0 2>/dev/null)
|
||||
BIN_DIR = "dist/bin"
|
||||
|
||||
# List of features to use when building. Can be overridden via the environment.
|
||||
@ -17,6 +19,9 @@ PROFILE ?= release
|
||||
# Extra flags for Cargo
|
||||
CARGO_INSTALL_EXTRA_FLAGS ?=
|
||||
|
||||
# The docker image name
|
||||
DOCKER_IMAGE_NAME ?= ghcr.io/hl-archive-node/nanoreth
|
||||
|
||||
##@ Help
|
||||
|
||||
.PHONY: help
|
||||
@ -207,3 +212,49 @@ check-features:
|
||||
--package reth-primitives-traits \
|
||||
--package reth-primitives \
|
||||
--feature-powerset
|
||||
|
||||
##@ Docker
|
||||
|
||||
# Note: This requires a buildx builder with emulation support. For example:
|
||||
#
|
||||
# `docker run --privileged --rm tonistiigi/binfmt --install amd64,arm64`
|
||||
# `docker buildx create --use --driver docker-container --name cross-builder`
|
||||
.PHONY: docker-build-push
|
||||
docker-build-push: ## Build and push a cross-arch Docker image tagged with the latest git tag.
|
||||
$(call docker_build_push,$(GIT_TAG),$(GIT_TAG))
|
||||
|
||||
# Note: This requires a buildx builder with emulation support. For example:
|
||||
#
|
||||
# `docker run --privileged --rm tonistiigi/binfmt --install amd64,arm64`
|
||||
# `docker buildx create --use --driver docker-container --name cross-builder`
|
||||
.PHONY: docker-build-push-git-sha
|
||||
docker-build-push-git-sha: ## Build and push a cross-arch Docker image tagged with the latest git sha.
|
||||
$(call docker_build_push,$(GIT_SHA),$(GIT_SHA))
|
||||
|
||||
# Note: This requires a buildx builder with emulation support. For example:
|
||||
#
|
||||
# `docker run --privileged --rm tonistiigi/binfmt --install amd64,arm64`
|
||||
# `docker buildx create --use --driver docker-container --name cross-builder`
|
||||
.PHONY: docker-build-push-latest
|
||||
docker-build-push-latest: ## Build and push a cross-arch Docker image tagged with the latest git tag and `latest`.
|
||||
$(call docker_build_push,$(GIT_TAG),latest)
|
||||
|
||||
# Note: This requires a buildx builder with emulation support. For example:
|
||||
#
|
||||
# `docker run --privileged --rm tonistiigi/binfmt --install amd64,arm64`
|
||||
# `docker buildx create --use --name cross-builder`
|
||||
.PHONY: docker-build-push-nightly
|
||||
docker-build-push-nightly: ## Build and push cross-arch Docker image tagged with the latest git tag with a `-nightly` suffix, and `latest-nightly`.
|
||||
$(call docker_build_push,nightly,nightly)
|
||||
|
||||
# Create a Docker image using the main Dockerfile
|
||||
define docker_build_push
|
||||
docker buildx build --file ./Dockerfile . \
|
||||
--platform linux/amd64 \
|
||||
--tag $(DOCKER_IMAGE_NAME):$(1) \
|
||||
--tag $(DOCKER_IMAGE_NAME):$(2) \
|
||||
--build-arg BUILD_PROFILE="$(PROFILE)" \
|
||||
--build-arg FEATURES="jemalloc,asm-keccak" \
|
||||
--provenance=false \
|
||||
--push
|
||||
endef
|
||||
|
||||
12
README.md
12
README.md
@ -3,6 +3,8 @@
|
||||
HyperEVM archive node implementation based on [reth](https://github.com/paradigmxyz/reth).
|
||||
NodeBuilder API version is heavily inspired by [reth-bsc](https://github.com/loocapro/reth-bsc).
|
||||
|
||||
Got questions? Drop by the [Hyperliquid Discord](https://discord.gg/hyperliquid) #node-operators channel.
|
||||
|
||||
## ⚠️ IMPORTANT: System Transactions Appear as Pseudo Transactions
|
||||
|
||||
Deposit transactions from [System Addresses](https://hyperliquid.gitbook.io/hyperliquid-docs/for-developers/hyperevm/hypercore-less-than-greater-than-hyperevm-transfers#system-addresses) like `0x222..22` / `0x200..xx` to user addresses are intentionally recorded as pseudo transactions.
|
||||
@ -58,19 +60,19 @@ $ reth-hl node --http --http.addr 0.0.0.0 --http.api eth,ots,net,web3 \
|
||||
|
||||
## How to run (testnet)
|
||||
|
||||
Testnet is supported since block 21304281.
|
||||
Testnet is supported since block 30281484.
|
||||
|
||||
```sh
|
||||
# Get testnet genesis at block 21304281
|
||||
# Get testnet genesis at block 30281484
|
||||
$ cd ~
|
||||
$ git clone https://github.com/sprites0/hl-testnet-genesis
|
||||
$ zstd --rm -d ~/hl-testnet-genesis/*.zst
|
||||
|
||||
# Init node
|
||||
$ make install
|
||||
$ reth-hl init-state --without-evm --chain testnet --header ~/hl-testnet-genesis/21304281.rlp \
|
||||
--header-hash 0x5b10856d2b1ad241c9bd6136bcc60ef7e8553560ca53995a590db65f809269b4 \
|
||||
~/hl-testnet-genesis/21304281.jsonl --total-difficulty 0
|
||||
$ reth-hl init-state --without-evm --chain testnet --header ~/hl-testnet-genesis/30281484.rlp \
|
||||
--header-hash 0x147cc3c09e9ddbb11799c826758db284f77099478ab5f528d3a57a6105516c21 \
|
||||
~/hl-testnet-genesis/30281484.jsonl --total-difficulty 0
|
||||
|
||||
# Run node
|
||||
$ reth-hl node --chain testnet --http --http.addr 0.0.0.0 --http.api eth,ots,net,web3 \
|
||||
|
||||
91
build.rs
Normal file
91
build.rs
Normal file
@ -0,0 +1,91 @@
|
||||
use std::{env, error::Error};
|
||||
use vergen::{BuildBuilder, CargoBuilder, Emitter};
|
||||
use vergen_git2::Git2Builder;
|
||||
|
||||
fn main() -> Result<(), Box<dyn Error>> {
|
||||
let mut emitter = Emitter::default();
|
||||
|
||||
let build_builder = BuildBuilder::default().build_timestamp(true).build()?;
|
||||
|
||||
emitter.add_instructions(&build_builder)?;
|
||||
|
||||
let cargo_builder = CargoBuilder::default().features(true).target_triple(true).build()?;
|
||||
|
||||
emitter.add_instructions(&cargo_builder)?;
|
||||
|
||||
let git_builder =
|
||||
Git2Builder::default().describe(false, true, None).dirty(true).sha(false).build()?;
|
||||
|
||||
emitter.add_instructions(&git_builder)?;
|
||||
|
||||
emitter.emit_and_set()?;
|
||||
let sha = env::var("VERGEN_GIT_SHA")?;
|
||||
let sha_short = &sha[0..7];
|
||||
|
||||
let is_dirty = env::var("VERGEN_GIT_DIRTY")? == "true";
|
||||
// > git describe --always --tags
|
||||
// if not on a tag: v0.2.0-beta.3-82-g1939939b
|
||||
// if on a tag: v0.2.0-beta.3
|
||||
let not_on_tag = env::var("VERGEN_GIT_DESCRIBE")?.ends_with(&format!("-g{sha_short}"));
|
||||
let version_suffix = if is_dirty || not_on_tag { "-dev" } else { "" };
|
||||
println!("cargo:rustc-env=RETH_HL_VERSION_SUFFIX={version_suffix}");
|
||||
|
||||
// Set short SHA
|
||||
println!("cargo:rustc-env=VERGEN_GIT_SHA_SHORT={}", &sha[..8]);
|
||||
|
||||
// Set the build profile
|
||||
let out_dir = env::var("OUT_DIR").unwrap();
|
||||
let profile = out_dir.rsplit(std::path::MAIN_SEPARATOR).nth(3).unwrap();
|
||||
println!("cargo:rustc-env=RETH_HL_BUILD_PROFILE={profile}");
|
||||
|
||||
// Set formatted version strings
|
||||
let pkg_version = env!("CARGO_PKG_VERSION");
|
||||
|
||||
// The short version information for reth.
|
||||
// - The latest version from Cargo.toml
|
||||
// - The short SHA of the latest commit.
|
||||
// Example: 0.1.0 (defa64b2)
|
||||
println!("cargo:rustc-env=RETH_HL_SHORT_VERSION={pkg_version}{version_suffix} ({sha_short})");
|
||||
|
||||
// LONG_VERSION
|
||||
// The long version information for reth.
|
||||
//
|
||||
// - The latest version from Cargo.toml + version suffix (if any)
|
||||
// - The full SHA of the latest commit
|
||||
// - The build datetime
|
||||
// - The build features
|
||||
// - The build profile
|
||||
//
|
||||
// Example:
|
||||
//
|
||||
// ```text
|
||||
// Version: 0.1.0
|
||||
// Commit SHA: defa64b2
|
||||
// Build Timestamp: 2023-05-19T01:47:19.815651705Z
|
||||
// Build Features: jemalloc
|
||||
// Build Profile: maxperf
|
||||
// ```
|
||||
println!("cargo:rustc-env=RETH_HL_LONG_VERSION_0=Version: {pkg_version}{version_suffix}");
|
||||
println!("cargo:rustc-env=RETH_HL_LONG_VERSION_1=Commit SHA: {sha}");
|
||||
println!(
|
||||
"cargo:rustc-env=RETH_HL_LONG_VERSION_2=Build Timestamp: {}",
|
||||
env::var("VERGEN_BUILD_TIMESTAMP")?
|
||||
);
|
||||
println!(
|
||||
"cargo:rustc-env=RETH_HL_LONG_VERSION_3=Build Features: {}",
|
||||
env::var("VERGEN_CARGO_FEATURES")?
|
||||
);
|
||||
println!("cargo:rustc-env=RETH_HL_LONG_VERSION_4=Build Profile: {profile}");
|
||||
|
||||
// The version information for reth formatted for P2P (devp2p).
|
||||
// - The latest version from Cargo.toml
|
||||
// - The target triple
|
||||
//
|
||||
// Example: reth/v0.1.0-alpha.1-428a6dc2f/aarch64-apple-darwin
|
||||
println!(
|
||||
"cargo:rustc-env=RETH_HL_P2P_CLIENT_VERSION={}",
|
||||
format_args!("reth/v{pkg_version}-{sha_short}/{}", env::var("VERGEN_CARGO_TARGET_TRIPLE")?)
|
||||
);
|
||||
|
||||
Ok(())
|
||||
}
|
||||
@ -37,10 +37,6 @@ impl EthChainSpec for HlChainSpec {
|
||||
self.inner.chain()
|
||||
}
|
||||
|
||||
fn base_fee_params_at_block(&self, block_number: u64) -> BaseFeeParams {
|
||||
self.inner.base_fee_params_at_block(block_number)
|
||||
}
|
||||
|
||||
fn base_fee_params_at_timestamp(&self, timestamp: u64) -> BaseFeeParams {
|
||||
self.inner.base_fee_params_at_timestamp(timestamp)
|
||||
}
|
||||
|
||||
@ -5,5 +5,6 @@ mod evm;
|
||||
mod hardforks;
|
||||
pub mod node;
|
||||
pub mod pseudo_peer;
|
||||
pub mod version;
|
||||
|
||||
pub use node::primitives::{HlBlock, HlBlockBody, HlPrimitives};
|
||||
|
||||
@ -31,6 +31,9 @@ fn main() -> eyre::Result<()> {
|
||||
std::env::set_var("RUST_BACKTRACE", "1");
|
||||
}
|
||||
|
||||
// Initialize custom version metadata before parsing CLI so --version uses reth-hl values
|
||||
reth_hl::version::init_reth_hl_version();
|
||||
|
||||
Cli::<HlChainSpecParser, HlNodeArgs>::parse().run(
|
||||
|builder: WithLaunchContext<NodeBuilder<Arc<DatabaseEnv>, HlChainSpec>>,
|
||||
ext: HlNodeArgs| async move {
|
||||
|
||||
@ -1,5 +1,6 @@
|
||||
use crate::node::primitives::TransactionSigned;
|
||||
use alloy_evm::eth::receipt_builder::{ReceiptBuilder, ReceiptBuilderCtx};
|
||||
use reth_codecs::alloy::transaction::Envelope;
|
||||
use reth_evm::Evm;
|
||||
use reth_primitives::Receipt;
|
||||
|
||||
|
||||
@ -1,20 +1,22 @@
|
||||
//! HlNodePrimitives::TransactionSigned; it's the same as ethereum transaction type,
|
||||
//! except that it supports pseudo signer for system transactions.
|
||||
use crate::evm::transaction::HlTxEnv;
|
||||
use alloy_consensus::{
|
||||
crypto::RecoveryError, error::ValueError, EthereumTxEnvelope, EthereumTypedTransaction,
|
||||
SignableTransaction, Signed, Transaction as TransactionTrait, TransactionEnvelope, TxEip1559,
|
||||
TxEip2930, TxEip4844, TxEip4844WithSidecar, TxEip7702, TxLegacy, TxType, TypedTransaction,
|
||||
crypto::RecoveryError, error::ValueError, SignableTransaction, Signed,
|
||||
Transaction as TransactionTrait, TransactionEnvelope, TxEip1559, TxEip2930, TxEip4844,
|
||||
TxEip7702, TxLegacy, TxType, TypedTransaction,
|
||||
};
|
||||
use alloy_eips::{eip7594::BlobTransactionSidecarVariant, Encodable2718};
|
||||
use alloy_eips::Encodable2718;
|
||||
use alloy_network::TxSigner;
|
||||
use alloy_primitives::{address, Address, TxHash, U256};
|
||||
use alloy_rpc_types::{Transaction, TransactionInfo, TransactionRequest};
|
||||
use alloy_signer::Signature;
|
||||
use reth_codecs::alloy::transaction::FromTxCompact;
|
||||
use reth_codecs::alloy::transaction::{Envelope, FromTxCompact};
|
||||
use reth_db::{
|
||||
table::{Compress, Decompress},
|
||||
DatabaseError,
|
||||
};
|
||||
use reth_ethereum_primitives::PooledTransactionVariant;
|
||||
use reth_evm::FromRecoveredTx;
|
||||
use reth_primitives::Recovered;
|
||||
use reth_primitives_traits::{
|
||||
@ -26,8 +28,6 @@ use reth_rpc_eth_api::{
|
||||
};
|
||||
use revm::context::{BlockEnv, CfgEnv, TxEnv};
|
||||
|
||||
use crate::evm::transaction::HlTxEnv;
|
||||
|
||||
type InnerType = alloy_consensus::EthereumTxEnvelope<TxEip4844>;
|
||||
|
||||
#[derive(Debug, Clone, TransactionEnvelope)]
|
||||
@ -157,16 +157,8 @@ impl TransactionSigned {
|
||||
}
|
||||
}
|
||||
|
||||
pub fn signature(&self) -> &Signature {
|
||||
self.inner().signature()
|
||||
}
|
||||
|
||||
pub const fn tx_type(&self) -> TxType {
|
||||
self.inner().tx_type()
|
||||
}
|
||||
|
||||
pub fn is_system_transaction(&self) -> bool {
|
||||
self.gas_price().is_some() && self.gas_price().unwrap() == 0
|
||||
matches!(self.gas_price(), Some(0))
|
||||
}
|
||||
}
|
||||
|
||||
@ -187,24 +179,16 @@ impl SerdeBincodeCompat for TransactionSigned {
|
||||
|
||||
pub type BlockBody = alloy_consensus::BlockBody<TransactionSigned>;
|
||||
|
||||
impl TryFrom<TransactionSigned>
|
||||
for EthereumTxEnvelope<TxEip4844WithSidecar<BlobTransactionSidecarVariant>>
|
||||
{
|
||||
type Error = <InnerType as TryInto<
|
||||
EthereumTxEnvelope<TxEip4844WithSidecar<BlobTransactionSidecarVariant>>,
|
||||
>>::Error;
|
||||
impl TryFrom<TransactionSigned> for PooledTransactionVariant {
|
||||
type Error = <InnerType as TryInto<PooledTransactionVariant>>::Error;
|
||||
|
||||
fn try_from(value: TransactionSigned) -> Result<Self, Self::Error> {
|
||||
value.into_inner().try_into()
|
||||
}
|
||||
}
|
||||
|
||||
impl From<EthereumTxEnvelope<TxEip4844WithSidecar<BlobTransactionSidecarVariant>>>
|
||||
for TransactionSigned
|
||||
{
|
||||
fn from(
|
||||
value: EthereumTxEnvelope<TxEip4844WithSidecar<BlobTransactionSidecarVariant>>,
|
||||
) -> Self {
|
||||
impl From<PooledTransactionVariant> for TransactionSigned {
|
||||
fn from(value: PooledTransactionVariant) -> Self {
|
||||
Self::Default(value.into())
|
||||
}
|
||||
}
|
||||
@ -277,26 +261,7 @@ impl SignableTxRequest<TransactionSigned> for TransactionRequest {
|
||||
self,
|
||||
signer: impl TxSigner<Signature> + Send,
|
||||
) -> Result<TransactionSigned, SignTxRequestError> {
|
||||
let mut tx =
|
||||
self.build_typed_tx().map_err(|_| SignTxRequestError::InvalidTransactionRequest)?;
|
||||
let signature = signer.sign_transaction(&mut tx).await?;
|
||||
let signed = match tx {
|
||||
EthereumTypedTransaction::Legacy(tx) => {
|
||||
EthereumTxEnvelope::Legacy(tx.into_signed(signature))
|
||||
}
|
||||
EthereumTypedTransaction::Eip2930(tx) => {
|
||||
EthereumTxEnvelope::Eip2930(tx.into_signed(signature))
|
||||
}
|
||||
EthereumTypedTransaction::Eip1559(tx) => {
|
||||
EthereumTxEnvelope::Eip1559(tx.into_signed(signature))
|
||||
}
|
||||
EthereumTypedTransaction::Eip4844(tx) => {
|
||||
EthereumTxEnvelope::Eip4844(TxEip4844::from(tx).into_signed(signature))
|
||||
}
|
||||
EthereumTypedTransaction::Eip7702(tx) => {
|
||||
EthereumTxEnvelope::Eip7702(tx.into_signed(signature))
|
||||
}
|
||||
};
|
||||
let signed = SignableTxRequest::<InnerType>::try_build_and_sign(self, signer).await?;
|
||||
Ok(TransactionSigned::Default(signed))
|
||||
}
|
||||
}
|
||||
|
||||
@ -3,7 +3,7 @@ use crate::{node::evm::apply_precompiles, HlBlock};
|
||||
use alloy_evm::Evm;
|
||||
use alloy_primitives::B256;
|
||||
use reth::rpc::server_types::eth::EthApiError;
|
||||
use reth_evm::{ConfigureEvm, Database, EvmEnvFor, TxEnvFor};
|
||||
use reth_evm::{ConfigureEvm, Database, EvmEnvFor, SpecFor, TxEnvFor};
|
||||
use reth_primitives::{NodePrimitives, Recovered};
|
||||
use reth_primitives_traits::SignedTransaction;
|
||||
use reth_provider::{ProviderError, ProviderTx};
|
||||
@ -19,7 +19,12 @@ impl<N, Rpc> EthCall for HlEthApi<N, Rpc>
|
||||
where
|
||||
N: HlRpcNodeCore,
|
||||
EthApiError: FromEvmError<N::Evm>,
|
||||
Rpc: RpcConvert<Primitives = N::Primitives, Error = EthApiError, TxEnv = TxEnvFor<N::Evm>>,
|
||||
Rpc: RpcConvert<
|
||||
Primitives = N::Primitives,
|
||||
Error = EthApiError,
|
||||
TxEnv = TxEnvFor<N::Evm>,
|
||||
Spec = SpecFor<N::Evm>,
|
||||
>,
|
||||
{
|
||||
}
|
||||
|
||||
@ -27,7 +32,12 @@ impl<N, Rpc> EstimateCall for HlEthApi<N, Rpc>
|
||||
where
|
||||
N: HlRpcNodeCore,
|
||||
EthApiError: FromEvmError<N::Evm>,
|
||||
Rpc: RpcConvert<Primitives = N::Primitives, Error = EthApiError, TxEnv = TxEnvFor<N::Evm>>,
|
||||
Rpc: RpcConvert<
|
||||
Primitives = N::Primitives,
|
||||
Error = EthApiError,
|
||||
TxEnv = TxEnvFor<N::Evm>,
|
||||
Spec = SpecFor<N::Evm>,
|
||||
>,
|
||||
{
|
||||
}
|
||||
|
||||
@ -35,7 +45,12 @@ impl<N, Rpc> Call for HlEthApi<N, Rpc>
|
||||
where
|
||||
N: HlRpcNodeCore,
|
||||
EthApiError: FromEvmError<N::Evm>,
|
||||
Rpc: RpcConvert<Primitives = N::Primitives, Error = EthApiError, TxEnv = TxEnvFor<N::Evm>>,
|
||||
Rpc: RpcConvert<
|
||||
Primitives = N::Primitives,
|
||||
Error = EthApiError,
|
||||
TxEnv = TxEnvFor<N::Evm>,
|
||||
Spec = SpecFor<N::Evm>,
|
||||
>,
|
||||
{
|
||||
#[inline]
|
||||
fn call_gas_limit(&self) -> u64 {
|
||||
|
||||
@ -31,7 +31,7 @@ use reth_rpc::RpcTypes;
|
||||
use reth_rpc_eth_api::{
|
||||
helpers::{
|
||||
pending_block::BuildPendingEnv, spec::SignersForApi, AddDevSigners, EthApiSpec, EthFees,
|
||||
EthState, LoadFee, LoadState, SpawnBlocking, Trace,
|
||||
EthState, LoadFee, LoadPendingBlock, LoadState, SpawnBlocking, Trace,
|
||||
},
|
||||
EthApiTypes, FromEvmError, RpcConvert, RpcConverter, RpcNodeCore, RpcNodeCoreExt,
|
||||
SignableTxRequest,
|
||||
@ -189,6 +189,7 @@ impl<N, Rpc> LoadState for HlEthApi<N, Rpc>
|
||||
where
|
||||
N: HlRpcNodeCore,
|
||||
Rpc: RpcConvert<Primitives = N::Primitives, Error = EthApiError>,
|
||||
Self: LoadPendingBlock,
|
||||
{
|
||||
}
|
||||
|
||||
@ -196,6 +197,7 @@ impl<N, Rpc> EthState for HlEthApi<N, Rpc>
|
||||
where
|
||||
N: HlRpcNodeCore,
|
||||
Rpc: RpcConvert<Primitives = N::Primitives, Error = EthApiError>,
|
||||
Self: LoadPendingBlock,
|
||||
{
|
||||
#[inline]
|
||||
fn max_proof_window(&self) -> u64 {
|
||||
|
||||
@ -14,6 +14,7 @@ use self::{
|
||||
use super::{BlockSource, BlockSourceBoxed};
|
||||
use crate::node::types::BlockAndReceipts;
|
||||
use futures::future::BoxFuture;
|
||||
use reth_metrics::{metrics, metrics::Counter, Metrics};
|
||||
use std::{
|
||||
path::{Path, PathBuf},
|
||||
sync::Arc,
|
||||
@ -41,6 +42,16 @@ pub struct HlNodeBlockSource {
|
||||
pub local_blocks_cache: Arc<Mutex<LocalBlocksCache>>,
|
||||
pub last_local_fetch: Arc<Mutex<Option<(u64, OffsetDateTime)>>>,
|
||||
pub args: HlNodeBlockSourceArgs,
|
||||
pub metrics: HlNodeBlockSourceMetrics,
|
||||
}
|
||||
|
||||
#[derive(Metrics, Clone)]
|
||||
#[metrics(scope = "block_source.hl_node")]
|
||||
pub struct HlNodeBlockSourceMetrics {
|
||||
/// How many times the HL node block source is polling for a block
|
||||
pub fetched_from_hl_node: Counter,
|
||||
/// How many times the HL node block source is fetched from the fallback
|
||||
pub fetched_from_fallback: Counter,
|
||||
}
|
||||
|
||||
impl BlockSource for HlNodeBlockSource {
|
||||
@ -49,11 +60,13 @@ impl BlockSource for HlNodeBlockSource {
|
||||
let args = self.args.clone();
|
||||
let local_blocks_cache = self.local_blocks_cache.clone();
|
||||
let last_local_fetch = self.last_local_fetch.clone();
|
||||
let metrics = self.metrics.clone();
|
||||
Box::pin(async move {
|
||||
let now = OffsetDateTime::now_utc();
|
||||
|
||||
if let Some(block) = Self::try_collect_local_block(local_blocks_cache, height).await {
|
||||
Self::update_last_fetch(last_local_fetch, height, now).await;
|
||||
metrics.fetched_from_hl_node.increment(1);
|
||||
return Ok(block);
|
||||
}
|
||||
|
||||
@ -68,6 +81,7 @@ impl BlockSource for HlNodeBlockSource {
|
||||
}
|
||||
|
||||
let block = fallback.collect_block(height).await?;
|
||||
metrics.fetched_from_fallback.increment(1);
|
||||
Self::update_last_fetch(last_local_fetch, height, now).await;
|
||||
Ok(block)
|
||||
})
|
||||
@ -224,6 +238,7 @@ impl HlNodeBlockSource {
|
||||
args,
|
||||
local_blocks_cache: Arc::new(Mutex::new(LocalBlocksCache::new(CACHE_SIZE))),
|
||||
last_local_fetch: Arc::new(Mutex::new(None)),
|
||||
metrics: HlNodeBlockSourceMetrics::default(),
|
||||
};
|
||||
block_source.run(next_block_number).await.unwrap();
|
||||
block_source
|
||||
|
||||
@ -2,6 +2,7 @@ use super::{utils, BlockSource};
|
||||
use crate::node::types::BlockAndReceipts;
|
||||
use eyre::Context;
|
||||
use futures::{future::BoxFuture, FutureExt};
|
||||
use reth_metrics::{metrics, metrics::Counter, Metrics};
|
||||
use std::path::PathBuf;
|
||||
use tracing::info;
|
||||
|
||||
@ -9,11 +10,21 @@ use tracing::info;
|
||||
#[derive(Debug, Clone)]
|
||||
pub struct LocalBlockSource {
|
||||
dir: PathBuf,
|
||||
metrics: LocalBlockSourceMetrics,
|
||||
}
|
||||
|
||||
#[derive(Metrics, Clone)]
|
||||
#[metrics(scope = "block_source.local")]
|
||||
pub struct LocalBlockSourceMetrics {
|
||||
/// How many times the local block source is polling for a block
|
||||
pub polling_attempt: Counter,
|
||||
/// How many times the local block source is fetched from the local filesystem
|
||||
pub fetched: Counter,
|
||||
}
|
||||
|
||||
impl LocalBlockSource {
|
||||
pub fn new(dir: impl Into<PathBuf>) -> Self {
|
||||
Self { dir: dir.into() }
|
||||
Self { dir: dir.into(), metrics: LocalBlockSourceMetrics::default() }
|
||||
}
|
||||
|
||||
async fn pick_path_with_highest_number(dir: PathBuf, is_dir: bool) -> Option<(u64, String)> {
|
||||
@ -31,13 +42,17 @@ impl LocalBlockSource {
|
||||
impl BlockSource for LocalBlockSource {
|
||||
fn collect_block(&self, height: u64) -> BoxFuture<'static, eyre::Result<BlockAndReceipts>> {
|
||||
let dir = self.dir.clone();
|
||||
let metrics = self.metrics.clone();
|
||||
async move {
|
||||
let path = dir.join(utils::rmp_path(height));
|
||||
metrics.polling_attempt.increment(1);
|
||||
|
||||
let file = tokio::fs::read(&path)
|
||||
.await
|
||||
.wrap_err_with(|| format!("Failed to read block from {path:?}"))?;
|
||||
let mut decoder = lz4_flex::frame::FrameDecoder::new(&file[..]);
|
||||
let blocks: Vec<BlockAndReceipts> = rmp_serde::from_read(&mut decoder)?;
|
||||
metrics.fetched.increment(1);
|
||||
Ok(blocks[0].clone())
|
||||
}
|
||||
.boxed()
|
||||
|
||||
@ -2,6 +2,7 @@ use super::{utils, BlockSource};
|
||||
use crate::node::types::BlockAndReceipts;
|
||||
use aws_sdk_s3::types::RequestPayer;
|
||||
use futures::{future::BoxFuture, FutureExt};
|
||||
use reth_metrics::{metrics, metrics::Counter, Metrics};
|
||||
use std::{sync::Arc, time::Duration};
|
||||
use tracing::info;
|
||||
|
||||
@ -11,11 +12,26 @@ pub struct S3BlockSource {
|
||||
client: Arc<aws_sdk_s3::Client>,
|
||||
bucket: String,
|
||||
polling_interval: Duration,
|
||||
metrics: S3BlockSourceMetrics,
|
||||
}
|
||||
|
||||
#[derive(Metrics, Clone)]
|
||||
#[metrics(scope = "block_source.s3")]
|
||||
pub struct S3BlockSourceMetrics {
|
||||
/// How many times the S3 block source is polling for a block
|
||||
pub polling_attempt: Counter,
|
||||
/// How many times the S3 block source has polled a block
|
||||
pub fetched: Counter,
|
||||
}
|
||||
|
||||
impl S3BlockSource {
|
||||
pub fn new(client: aws_sdk_s3::Client, bucket: String, polling_interval: Duration) -> Self {
|
||||
Self { client: client.into(), bucket, polling_interval }
|
||||
Self {
|
||||
client: client.into(),
|
||||
bucket,
|
||||
polling_interval,
|
||||
metrics: S3BlockSourceMetrics::default(),
|
||||
}
|
||||
}
|
||||
|
||||
async fn pick_path_with_highest_number(
|
||||
@ -52,14 +68,18 @@ impl BlockSource for S3BlockSource {
|
||||
fn collect_block(&self, height: u64) -> BoxFuture<'static, eyre::Result<BlockAndReceipts>> {
|
||||
let client = self.client.clone();
|
||||
let bucket = self.bucket.clone();
|
||||
let metrics = self.metrics.clone();
|
||||
async move {
|
||||
let path = utils::rmp_path(height);
|
||||
metrics.polling_attempt.increment(1);
|
||||
|
||||
let request = client
|
||||
.get_object()
|
||||
.request_payer(RequestPayer::Requester)
|
||||
.bucket(&bucket)
|
||||
.key(path);
|
||||
let response = request.send().await?;
|
||||
metrics.fetched.increment(1);
|
||||
let bytes = response.body.collect().await?.into_bytes();
|
||||
let mut decoder = lz4_flex::frame::FrameDecoder::new(&bytes[..]);
|
||||
let blocks: Vec<BlockAndReceipts> = rmp_serde::from_read(&mut decoder)?;
|
||||
|
||||
35
src/version.rs
Normal file
35
src/version.rs
Normal file
@ -0,0 +1,35 @@
|
||||
use std::borrow::Cow;
|
||||
|
||||
use reth_node_core::version::{try_init_version_metadata, RethCliVersionConsts};
|
||||
|
||||
pub fn init_reth_hl_version() {
|
||||
let cargo_pkg_version = env!("CARGO_PKG_VERSION").to_string();
|
||||
|
||||
let short = env!("RETH_HL_SHORT_VERSION").to_string();
|
||||
let long = format!(
|
||||
"{}\n{}\n{}\n{}\n{}",
|
||||
env!("RETH_HL_LONG_VERSION_0"),
|
||||
env!("RETH_HL_LONG_VERSION_1"),
|
||||
env!("RETH_HL_LONG_VERSION_2"),
|
||||
env!("RETH_HL_LONG_VERSION_3"),
|
||||
env!("RETH_HL_LONG_VERSION_4"),
|
||||
);
|
||||
let p2p = env!("RETH_HL_P2P_CLIENT_VERSION").to_string();
|
||||
|
||||
let meta = RethCliVersionConsts {
|
||||
name_client: Cow::Borrowed("reth_hl"),
|
||||
cargo_pkg_version: Cow::Owned(cargo_pkg_version.clone()),
|
||||
vergen_git_sha_long: Cow::Owned(env!("VERGEN_GIT_SHA").to_string()),
|
||||
vergen_git_sha: Cow::Owned(env!("VERGEN_GIT_SHA_SHORT").to_string()),
|
||||
vergen_build_timestamp: Cow::Owned(env!("VERGEN_BUILD_TIMESTAMP").to_string()),
|
||||
vergen_cargo_target_triple: Cow::Owned(env!("VERGEN_CARGO_TARGET_TRIPLE").to_string()),
|
||||
vergen_cargo_features: Cow::Owned(env!("VERGEN_CARGO_FEATURES").to_string()),
|
||||
short_version: Cow::Owned(short),
|
||||
long_version: Cow::Owned(long),
|
||||
build_profile_name: Cow::Owned(env!("RETH_HL_BUILD_PROFILE").to_string()),
|
||||
p2p_client_version: Cow::Owned(p2p),
|
||||
extra_data: Cow::Owned(format!("reth_hl/v{}/{}", cargo_pkg_version, std::env::consts::OS)),
|
||||
};
|
||||
|
||||
let _ = try_init_version_metadata(meta);
|
||||
}
|
||||
Reference in New Issue
Block a user