Skip to content

Commit

Permalink
feat: add ws_url to el_context (#696)
Browse files Browse the repository at this point in the history
  • Loading branch information
barnabasbusa authored Jun 27, 2024
1 parent 2711cff commit 26fea61
Show file tree
Hide file tree
Showing 8 changed files with 16 additions and 0 deletions.
2 changes: 2 additions & 0 deletions src/el/besu/besu_launcher.star
Original file line number Diff line number Diff line change
Expand Up @@ -147,6 +147,7 @@ def launch(
service_name, METRICS_PATH, metrics_url
)
http_url = "http://{0}:{1}".format(service.ip_address, RPC_PORT_NUM)
ws_url = "ws://{0}:{1}".format(service.ip_address, WS_PORT_NUM)

return el_context.new_el_context(
"besu",
Expand All @@ -157,6 +158,7 @@ def launch(
WS_PORT_NUM,
ENGINE_HTTP_RPC_PORT_NUM,
http_url,
ws_url,
service_name,
[besu_metrics_info],
)
Expand Down
2 changes: 2 additions & 0 deletions src/el/el_context.star
Original file line number Diff line number Diff line change
Expand Up @@ -7,6 +7,7 @@ def new_el_context(
ws_port_num,
engine_rpc_port_num,
rpc_http_url,
ws_url,
service_name="",
el_metrics_info=None,
):
Expand All @@ -20,5 +21,6 @@ def new_el_context(
ws_port_num=ws_port_num,
engine_rpc_port_num=engine_rpc_port_num,
rpc_http_url=rpc_http_url,
ws_url=ws_url,
el_metrics_info=el_metrics_info,
)
2 changes: 2 additions & 0 deletions src/el/erigon/erigon_launcher.star
Original file line number Diff line number Diff line change
Expand Up @@ -148,6 +148,7 @@ def launch(
)

http_url = "http://{0}:{1}".format(service.ip_address, WS_RPC_PORT_NUM)
ws_url = "ws://{0}:{1}".format(service.ip_address, WS_RPC_PORT_NUM)

return el_context.new_el_context(
"erigon",
Expand All @@ -158,6 +159,7 @@ def launch(
WS_RPC_PORT_NUM,
ENGINE_RPC_PORT_NUM,
http_url,
ws_url,
service_name,
[erigon_metrics_info],
)
Expand Down
2 changes: 2 additions & 0 deletions src/el/ethereumjs/ethereumjs_launcher.star
Original file line number Diff line number Diff line change
Expand Up @@ -148,6 +148,7 @@ def launch(
ethjs_metrics_info = None

http_url = "http://{0}:{1}".format(service.ip_address, RPC_PORT_NUM)
ws_url = "ws://{0}:{1}".format(service.ip_address, WS_PORT_NUM)

return el_context.new_el_context(
"ethereumjs",
Expand All @@ -158,6 +159,7 @@ def launch(
WS_PORT_NUM,
ENGINE_RPC_PORT_NUM,
http_url,
ws_url,
service_name,
[ethjs_metrics_info],
)
Expand Down
2 changes: 2 additions & 0 deletions src/el/geth/geth_launcher.star
Original file line number Diff line number Diff line change
Expand Up @@ -163,6 +163,7 @@ def launch(
)

http_url = "http://{0}:{1}".format(service.ip_address, RPC_PORT_NUM)
ws_url = "ws://{0}:{1}".format(service.ip_address, WS_PORT_NUM)

return el_context.new_el_context(
"geth",
Expand All @@ -173,6 +174,7 @@ def launch(
WS_PORT_NUM,
ENGINE_RPC_PORT_NUM,
http_url,
ws_url,
service_name,
[geth_metrics_info],
)
Expand Down
2 changes: 2 additions & 0 deletions src/el/nethermind/nethermind_launcher.star
Original file line number Diff line number Diff line change
Expand Up @@ -145,6 +145,7 @@ def launch(
)

http_url = "http://{0}:{1}".format(service.ip_address, RPC_PORT_NUM)
ws_url = "ws://{0}:{1}".format(service.ip_address, WS_PORT_NUM)

return el_context.new_el_context(
"nethermind",
Expand All @@ -156,6 +157,7 @@ def launch(
WS_PORT_NUM,
ENGINE_RPC_PORT_NUM,
http_url,
ws_url,
service_name,
[nethermind_metrics_info],
)
Expand Down
2 changes: 2 additions & 0 deletions src/el/nimbus-eth1/nimbus_launcher.star
Original file line number Diff line number Diff line change
Expand Up @@ -147,6 +147,7 @@ def launch(
)

http_url = "http://{0}:{1}".format(service.ip_address, WS_RPC_PORT_NUM)
ws_url = "ws://{0}:{1}".format(service.ip_address, WS_RPC_PORT_NUM)

return el_context.new_el_context(
"nimbus",
Expand All @@ -157,6 +158,7 @@ def launch(
WS_RPC_PORT_NUM,
ENGINE_RPC_PORT_NUM,
http_url,
ws_url,
service_name,
[nimbus_metrics_info],
)
Expand Down
2 changes: 2 additions & 0 deletions src/el/reth/reth_launcher.star
Original file line number Diff line number Diff line change
Expand Up @@ -150,6 +150,7 @@ def launch(
)

http_url = "http://{0}:{1}".format(service.ip_address, RPC_PORT_NUM)
ws_url = "ws://{0}:{1}".format(service.ip_address, WS_PORT_NUM)

return el_context.new_el_context(
"reth",
Expand All @@ -160,6 +161,7 @@ def launch(
WS_PORT_NUM,
ENGINE_RPC_PORT_NUM,
http_url,
ws_url,
service_name,
[reth_metrics_info],
)
Expand Down

0 comments on commit 26fea61

Please sign in to comment.