Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
33 commits
Select commit Hold shift + click to select a range
a4d5f14
add depends on
tedim52 Oct 2, 2025
0d4f793
add back verifies
tedim52 Oct 2, 2025
de1b354
fix typo
tedim52 Oct 2, 2025
ab141a7
Merge branch 'main' into tedi/newparallel
tedim52 Nov 5, 2025
4567728
lint
tedim52 Nov 5, 2025
afc7bc8
add ip address to el context
tedim52 Nov 5, 2025
624c2ec
swap ip addr with dns name
tedim52 Nov 5, 2025
82105f8
revert change for cls
tedim52 Nov 5, 2025
4aa6368
remove fuzz target
tedim52 Nov 5, 2025
58dc090
fix spamoor
tedim52 Nov 6, 2025
473dd2f
Merge branch 'main' into tedi/newparallel
barnabasbusa Nov 26, 2025
ee8ca4d
add parallel to ci jobs by default
barnabasbusa Nov 26, 2025
505559b
add parallel to ci jobs by default
barnabasbusa Nov 26, 2025
73b5899
Merge branch 'main' into tedi/newparallel
barnabasbusa Nov 26, 2025
69e0779
assert test minimal
barnabasbusa Nov 26, 2025
05feccf
Merge branch 'main' into tedi/newparallel
tedim52 Nov 28, 2025
bd58b44
Merge branch 'main' into tedi/newparallel
barnabasbusa Dec 2, 2025
32d6f9e
Merge branch 'main' into tedi/newparallel
barnabasbusa Dec 9, 2025
96951ea
Merge branch 'main' into tedi/newparallel
barnabasbusa Dec 10, 2025
d9cfd0e
try using ip address for cl context http url
tedim52 Dec 10, 2025
0b069a8
lint
tedim52 Dec 10, 2025
df96f5b
just for mev mock
tedim52 Dec 10, 2025
8698f37
add ip address
tedim52 Dec 10, 2025
159161a
add ip address
tedim52 Dec 10, 2025
0fb453e
lint
tedim52 Dec 10, 2025
78fd879
Merge branch 'main' into tedi/newparallel
tedim52 Dec 16, 2025
c85d94c
Merge branch 'main' into tedi/newparallel
barnabasbusa Dec 17, 2025
eb09ec4
Update nightly.yml
barnabasbusa Dec 17, 2025
fd53774
Update per-pr.yml
barnabasbusa Dec 17, 2025
ae7301a
Merge branch 'main' into tedi/newparallel
barnabasbusa Dec 17, 2025
6d37633
remove unused field
barnabasbusa Dec 17, 2025
4ab43cf
fix some tests and blobber dns
barnabasbusa Dec 17, 2025
986ec53
fix another test
barnabasbusa Dec 17, 2025
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
2 changes: 0 additions & 2 deletions .github/tests/deneb.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -16,8 +16,6 @@ participants:
cl_type: lodestar
additional_services:
- dora
- spamoor
- blockscout
network_params:
altair_fork_epoch: 0
bellatrix_fork_epoch: 0
Expand Down
2 changes: 2 additions & 0 deletions .github/tests/mev-pectra.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -55,6 +55,8 @@ network_params:
shard_committee_period: 1
churn_limit_quotient: 16
prefunded_accounts: '{"0xb9e79D19f651a941757b35830232E7EFC77E1c79": {"balance": "100000ETH"}}'
electra_fork_epoch: 0
fulu_fork_epoch: 100

assertoor_params:
tests:
Expand Down
2 changes: 2 additions & 0 deletions .github/tests/mix-assert.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -11,6 +11,8 @@ participants:
cl_type: lodestar
- el_type: ethrex
cl_type: grandine
network_params:
preset: minimal
additional_services:
- assertoor
- dora
Expand Down
1 change: 1 addition & 0 deletions .github/tests/nimbus-mev.yaml
Original file line number Diff line number Diff line change
@@ -1,4 +1,5 @@
participants:
- el_type: geth
cl_type: nimbus
cl_image: ethpandaops/nimbus-eth2:unstable
mev_type: flashbots
18 changes: 11 additions & 7 deletions main.star
Original file line number Diff line number Diff line change
Expand Up @@ -259,7 +259,7 @@ def run(plan, args={}):

plan.print(
"NODE JSON RPC URI: '{0}:{1}'".format(
all_participants[0].el_context.ip_addr,
all_participants[0].el_context.dns_name,
all_participants[0].el_context.rpc_port_num,
)
)
Expand Down Expand Up @@ -327,16 +327,20 @@ def run(plan, args={}):
and args_with_right_defaults.mev_type == constants.MOCK_MEV_TYPE
):
el_uri = "{0}:{1}".format(
all_el_contexts[0].ip_addr,
all_el_contexts[0].dns_name,
all_el_contexts[0].engine_rpc_port_num,
)
beacon_uri = "{0}".format(all_cl_contexts[0].beacon_http_url)[
7:
] # remove http://

# beacon uri for mock mev needs to use ip address and not dns name
beacon_uri_for_mock_mev = "{0}:{1}".format(
all_cl_contexts[0].ip_address,
all_cl_contexts[0].http_port,
)

endpoint = mock_mev.launch_mock_mev(
plan,
el_uri,
beacon_uri,
beacon_uri_for_mock_mev,
jwt_file,
args_with_right_defaults.global_log_level,
global_node_selectors,
Expand All @@ -352,7 +356,7 @@ def run(plan, args={}):
or args_with_right_defaults.mev_type == constants.HELIX_MEV_TYPE
):
blocksim_uri = "http://{0}:{1}".format(
all_el_contexts[-1].ip_addr, all_el_contexts[-1].rpc_port_num
all_el_contexts[-1].dns_name, all_el_contexts[-1].rpc_port_num
)
beacon_uri = all_cl_contexts[-1].beacon_http_url

Expand Down
6 changes: 3 additions & 3 deletions src/assertoor/assertoor_launcher.star
Original file line number Diff line number Diff line change
Expand Up @@ -69,7 +69,7 @@ def launch_assertoor(

client_info = new_client_info(
cl_client.beacon_http_url,
el_client.ip_addr,
el_client.dns_name,
el_client.rpc_port_num,
participant.snooper_el_engine_context,
participant.snooper_beacon_context,
Expand Down Expand Up @@ -218,13 +218,13 @@ def new_client_info(
if el_snooper_context != None:
el_snooper_enabled = True
el_snooper_url = "http://{0}:{1}".format(
el_snooper_context.ip_addr,
el_snooper_context.dns_name,
el_snooper_context.engine_rpc_port_num,
)
if cl_snooper_context != None:
cl_snooper_enabled = True
cl_snooper_url = "http://{0}:{1}".format(
cl_snooper_context.ip_addr,
cl_snooper_context.dns_name,
cl_snooper_context.beacon_rpc_port_num,
)

Expand Down
4 changes: 2 additions & 2 deletions src/blobber/blobber_context.star
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
def new_blobber_context(ip_addr, port_num):
def new_blobber_context(dns_name, port_num):
return struct(
ip_addr=ip_addr,
dns_name=dns_name,
port_num=port_num,
)
2 changes: 1 addition & 1 deletion src/blockscout/blockscout_launcher.star
Original file line number Diff line number Diff line change
Expand Up @@ -89,7 +89,7 @@ def launch_blockscout(

el_context = el_contexts[0]
el_client_rpc_url = "http://{}:{}/".format(
el_context.ip_addr, el_context.rpc_port_num
el_context.dns_name, el_context.rpc_port_num
)
el_client_name = el_context.client_name

Expand Down
2 changes: 1 addition & 1 deletion src/blutgang/blutgang_launcher.star
Original file line number Diff line number Diff line change
Expand Up @@ -54,7 +54,7 @@ def launch_blutgang(
)
all_el_client_info.append(
new_el_client_info(
el_client.ip_addr,
el_client.dns_name,
el_client.rpc_port_num,
el_client.ws_port_num,
full_name,
Expand Down
2 changes: 1 addition & 1 deletion src/broadcaster/broadcaster.star
Original file line number Diff line number Diff line change
Expand Up @@ -28,7 +28,7 @@ def get_config(
return ServiceConfig(
image=IMAGE_NAME,
cmd=[
"http://{0}:{1}".format(context.ip_addr, context.rpc_port_num)
"http://{0}:{1}".format(context.dns_name, context.rpc_port_num)
for context in all_el_contexts
],
min_cpu=MIN_CPU,
Expand Down
2 changes: 2 additions & 0 deletions src/cl/cl_context.star
Original file line number Diff line number Diff line change
Expand Up @@ -4,6 +4,7 @@ def new_cl_context(
ip_addr,
http_port,
beacon_http_url,
ip_address="",
cl_nodes_metrics_info=None,
beacon_service_name="",
beacon_grpc_url="",
Expand All @@ -18,6 +19,7 @@ def new_cl_context(
client_name=client_name,
enr=enr,
ip_addr=ip_addr,
ip_address=ip_address,
http_port=http_port,
beacon_http_url=beacon_http_url,
cl_nodes_metrics_info=cl_nodes_metrics_info,
Expand Down
2 changes: 1 addition & 1 deletion src/cl/grandine/grandine_launcher.star
Original file line number Diff line number Diff line change
Expand Up @@ -147,7 +147,7 @@ def get_beacon_config(
)
else:
EXECUTION_ENGINE_ENDPOINT = "http://{0}:{1}".format(
el_context.ip_addr,
el_context.dns_name,
el_context.engine_rpc_port_num,
)

Expand Down
3 changes: 2 additions & 1 deletion src/cl/lighthouse/lighthouse_launcher.star
Original file line number Diff line number Diff line change
Expand Up @@ -139,7 +139,7 @@ def get_beacon_config(
)
else:
EXECUTION_ENGINE_ENDPOINT = "http://{0}:{1}".format(
el_context.ip_addr,
el_context.dns_name,
el_context.engine_rpc_port_num,
)

Expand Down Expand Up @@ -398,6 +398,7 @@ def get_cl_context(
client_name="lighthouse",
enr=beacon_node_enr,
ip_addr=service.name,
ip_address=service.ip_address,
http_port=beacon_http_port.number,
beacon_http_url=beacon_http_url,
cl_nodes_metrics_info=nodes_metrics_info,
Expand Down
4 changes: 2 additions & 2 deletions src/cl/lodestar/lodestar_launcher.star
Original file line number Diff line number Diff line change
Expand Up @@ -121,7 +121,7 @@ def get_beacon_config(
)

el_client_rpc_url_str = "http://{0}:{1}".format(
el_context.ip_addr,
el_context.dns_name,
el_context.rpc_port_num,
)

Expand All @@ -133,7 +133,7 @@ def get_beacon_config(
)
else:
EXECUTION_ENGINE_ENDPOINT = "http://{0}:{1}".format(
el_context.ip_addr,
el_context.dns_name,
el_context.engine_rpc_port_num,
)

Expand Down
2 changes: 1 addition & 1 deletion src/cl/nimbus/nimbus_launcher.star
Original file line number Diff line number Diff line change
Expand Up @@ -157,7 +157,7 @@ def get_beacon_config(
)
else:
EXECUTION_ENGINE_ENDPOINT = "http://{0}:{1}".format(
el_context.ip_addr,
el_context.dns_name,
el_context.engine_rpc_port_num,
)

Expand Down
2 changes: 1 addition & 1 deletion src/cl/prysm/prysm_launcher.star
Original file line number Diff line number Diff line change
Expand Up @@ -131,7 +131,7 @@ def get_beacon_config(
)
else:
EXECUTION_ENGINE_ENDPOINT = "http://{0}:{1}".format(
el_context.ip_addr,
el_context.dns_name,
el_context.engine_rpc_port_num,
)

Expand Down
2 changes: 1 addition & 1 deletion src/cl/teku/teku_launcher.star
Original file line number Diff line number Diff line change
Expand Up @@ -142,7 +142,7 @@ def get_beacon_config(
)
else:
EXECUTION_ENGINE_ENDPOINT = "http://{0}:{1}".format(
el_context.ip_addr,
el_context.dns_name,
el_context.engine_rpc_port_num,
)

Expand Down
2 changes: 1 addition & 1 deletion src/dora/dora_launcher.star
Original file line number Diff line number Diff line change
Expand Up @@ -71,7 +71,7 @@ def launch_dora(
all_el_client_info.append(
new_el_client_info(
"http://{0}:{1}".format(
el_client.ip_addr,
el_client.dns_name,
el_client.rpc_port_num,
),
execution_snooper_url,
Expand Down
3 changes: 2 additions & 1 deletion src/el/besu/besu_launcher.star
Original file line number Diff line number Diff line change
Expand Up @@ -303,14 +303,15 @@ def get_el_context(
return el_context.new_el_context(
client_name="besu",
enode=enode,
ip_addr=service.name,
dns_name=service.name,
rpc_port_num=RPC_PORT_NUM,
ws_port_num=WS_PORT_NUM,
engine_rpc_port_num=ENGINE_HTTP_RPC_PORT_NUM,
rpc_http_url=http_url,
ws_url=ws_url,
service_name=service_name,
el_metrics_info=[besu_metrics_info],
ip_addr=service.ip_address,
)


Expand Down
6 changes: 4 additions & 2 deletions src/el/el_context.star
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
def new_el_context(
client_name,
enode,
ip_addr,
dns_name,
rpc_port_num,
ws_port_num,
engine_rpc_port_num,
Expand All @@ -10,11 +10,12 @@ def new_el_context(
enr="",
service_name="",
el_metrics_info=None,
ip_addr="",
):
return struct(
client_name=client_name,
enode=enode,
ip_addr=ip_addr,
dns_name=dns_name,
rpc_port_num=rpc_port_num,
ws_port_num=ws_port_num,
engine_rpc_port_num=engine_rpc_port_num,
Expand All @@ -23,4 +24,5 @@ def new_el_context(
enr=enr,
service_name=service_name,
el_metrics_info=el_metrics_info,
ip_addr=ip_addr,
)
3 changes: 2 additions & 1 deletion src/el/erigon/erigon_launcher.star
Original file line number Diff line number Diff line change
Expand Up @@ -309,7 +309,7 @@ def get_el_context(
return el_context.new_el_context(
client_name="erigon",
enode=enode,
ip_addr=service.name,
dns_name=service.name,
rpc_port_num=WS_RPC_PORT_NUM,
ws_port_num=WS_RPC_PORT_NUM,
engine_rpc_port_num=ENGINE_RPC_PORT_NUM,
Expand All @@ -318,6 +318,7 @@ def get_el_context(
enr=enr,
service_name=service_name,
el_metrics_info=[erigon_metrics_info],
ip_addr=service.ip_address,
)


Expand Down
3 changes: 2 additions & 1 deletion src/el/ethereumjs/ethereumjs_launcher.star
Original file line number Diff line number Diff line change
Expand Up @@ -294,14 +294,15 @@ def get_el_context(
return el_context.new_el_context(
client_name="ethereumjs",
enode=enode,
ip_addr=service.name,
dns_name=service.name,
rpc_port_num=RPC_PORT_NUM,
ws_port_num=WS_PORT_NUM,
engine_rpc_port_num=ENGINE_RPC_PORT_NUM,
rpc_http_url=http_url,
ws_url=ws_url,
service_name=service_name,
el_metrics_info=[ethjs_metrics_info],
ip_addr=service.ip_address,
)


Expand Down
3 changes: 2 additions & 1 deletion src/el/ethrex/ethrex_launcher.star
Original file line number Diff line number Diff line change
Expand Up @@ -287,7 +287,7 @@ def get_el_context(
return el_context.new_el_context(
client_name="ethrex",
enode=enode,
ip_addr=service.name,
dns_name=service.name,
rpc_port_num=RPC_PORT_NUM,
ws_port_num=WS_PORT_NUM,
engine_rpc_port_num=ENGINE_RPC_PORT_NUM,
Expand All @@ -296,6 +296,7 @@ def get_el_context(
enr=enr,
service_name=service_name,
el_metrics_info=[ethrex_metrics_info],
ip_addr=service.ip_address,
)


Expand Down
3 changes: 2 additions & 1 deletion src/el/geth/geth_launcher.star
Original file line number Diff line number Diff line change
Expand Up @@ -337,7 +337,7 @@ def get_el_context(
return el_context.new_el_context(
client_name="geth",
enode=enode,
ip_addr=service.name,
dns_name=service.name,
rpc_port_num=RPC_PORT_NUM,
ws_port_num=WS_PORT_NUM,
engine_rpc_port_num=ENGINE_RPC_PORT_NUM,
Expand All @@ -346,6 +346,7 @@ def get_el_context(
enr=enr,
service_name=service_name,
el_metrics_info=[geth_metrics_info],
ip_addr=service.ip_address,
)


Expand Down
3 changes: 2 additions & 1 deletion src/el/nethermind/nethermind_launcher.star
Original file line number Diff line number Diff line change
Expand Up @@ -295,14 +295,15 @@ def get_el_context(
return el_context.new_el_context(
client_name="nethermind",
enode=enode,
ip_addr=service.name,
dns_name=service.name,
rpc_port_num=RPC_PORT_NUM,
ws_port_num=WS_PORT_NUM,
engine_rpc_port_num=ENGINE_RPC_PORT_NUM,
rpc_http_url=http_url,
ws_url=ws_url,
service_name=service_name,
el_metrics_info=[nethermind_metrics_info],
ip_addr=service.ip_address,
)


Expand Down
3 changes: 2 additions & 1 deletion src/el/nimbus-eth1/nimbus_launcher.star
Original file line number Diff line number Diff line change
Expand Up @@ -277,14 +277,15 @@ def get_el_context(
return el_context.new_el_context(
client_name="nimbus",
enode=enode,
ip_addr=service.name,
dns_name=service.name,
rpc_port_num=WS_RPC_PORT_NUM,
ws_port_num=WS_RPC_PORT_NUM,
engine_rpc_port_num=ENGINE_RPC_PORT_NUM,
rpc_http_url=http_url,
ws_url=ws_url,
service_name=service_name,
el_metrics_info=[nimbus_metrics_info],
ip_addr=service.ip_address,
)


Expand Down
3 changes: 2 additions & 1 deletion src/el/reth/reth_launcher.star
Original file line number Diff line number Diff line change
Expand Up @@ -356,14 +356,15 @@ def get_el_context(
return el_context.new_el_context(
client_name="reth-builder" if launcher.builder_type else "reth",
enode=enode,
ip_addr=service.name,
dns_name=service.name,
rpc_port_num=RPC_PORT_NUM,
ws_port_num=WS_PORT_NUM,
engine_rpc_port_num=ENGINE_RPC_PORT_NUM,
rpc_http_url=http_url,
ws_url=ws_url,
service_name=service_name,
el_metrics_info=[reth_metrics_info],
ip_addr=service.ip_address,
)


Expand Down
Loading