Skip to content
Projects
Groups
Snippets
Help
Loading...
Help
Support
Submit feedback
Contribute to GitLab
Sign in
Toggle navigation
E
ethereum-package
Project
Project
Details
Activity
Releases
Cycle Analytics
Repository
Repository
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Charts
Issues
0
Issues
0
List
Boards
Labels
Milestones
Merge Requests
0
Merge Requests
0
CI / CD
CI / CD
Pipelines
Jobs
Schedules
Charts
Wiki
Wiki
Snippets
Snippets
Members
Members
Collapse sidebar
Close sidebar
Activity
Graph
Charts
Create a new issue
Jobs
Commits
Issue Boards
Open sidebar
vicotor
ethereum-package
Commits
12215c2e
Commit
12215c2e
authored
Nov 22, 2022
by
Gyanendra Mishra
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
fix besu
parent
23be10e9
Changes
1
Show whitespace changes
Inline
Side-by-side
Showing
1 changed file
with
13 additions
and
13 deletions
+13
-13
besu_launcher.star
src/participant_network/el/besu/besu_launcher.star
+13
-13
No files found.
src/participant_network/el/besu/besu_launcher.star
View file @
12215c2e
load("github.com/kurtosis-tech/eth2-module/src/shared_utils/shared_utils.star", "new_port_spec", "path_join", "TCP_PROTOCOL", "UDP_PROTOCOL
")
shared_utils = import_module("github.com/kurtosis-tech/eth2-module/src/shared_utils/shared_utils.star
")
load("github.com/kurtosis-tech/eth2-module/src/module_io/parse_input.star", "get_client_log_level_or_default
")
parse_input = import_module("github.com/kurtosis-tech/eth2-module/src/module_io/parse_input.star
")
load("github.com/kurtosis-tech/eth2-module/src/participant_network/el/el_client_context.star", "new_el_client_context
")
el_client_context = import_module("github.com/kurtosis-tech/eth2-module/src/participant_network/el/el_client_context.star
")
module_io = import_types("github.com/kurtosis-tech/eth2-module/types.proto")
module_io = import_types("github.com/kurtosis-tech/eth2-module/types.proto")
...
@@ -26,12 +26,12 @@ ENGINE_WS_RPC_PORT_ID = "engineWsRpc"
...
@@ -26,12 +26,12 @@ ENGINE_WS_RPC_PORT_ID = "engineWsRpc"
PRIVATE_IP_ADDRESS_PLACEHOLDER = "KURTOSIS_IP_ADDR_PLACEHOLDER"
PRIVATE_IP_ADDRESS_PLACEHOLDER = "KURTOSIS_IP_ADDR_PLACEHOLDER"
USED_PORTS = {
USED_PORTS = {
RPC_PORT_ID:
new_port_spec(RPC_PORT_NUM,
TCP_PROTOCOL),
RPC_PORT_ID:
shared_utils.new_port_spec(RPC_PORT_NUM, shared_utils.
TCP_PROTOCOL),
WS_PORT_ID:
new_port_spec(WS_PORT_NUM,
TCP_PROTOCOL),
WS_PORT_ID:
shared_utils.new_port_spec(WS_PORT_NUM, shared_utils.
TCP_PROTOCOL),
TCP_DISCOVERY_PORT_ID:
new_port_spec(DISCOVERY_PORT_NUM,
TCP_PROTOCOL),
TCP_DISCOVERY_PORT_ID:
shared_utils.new_port_spec(DISCOVERY_PORT_NUM, shared_utils.
TCP_PROTOCOL),
UDP_DISCOVERY_PORT_ID:
new_port_spec(DISCOVERY_PORT_NUM,
UDP_PROTOCOL),
UDP_DISCOVERY_PORT_ID:
shared_utils.new_port_spec(DISCOVERY_PORT_NUM, shared_utils.
UDP_PROTOCOL),
ENGINE_HTTP_RPC_PORT_ID:
new_port_spec(ENGINE_HTTP_RPC_PORT_NUM,
TCP_PROTOCOL),
ENGINE_HTTP_RPC_PORT_ID:
shared_utils.new_port_spec(ENGINE_HTTP_RPC_PORT_NUM, shared_utils.
TCP_PROTOCOL),
ENGINE_WS_RPC_PORT_ID:
new_port_spec(ENGINE_WS_RPC_PORT_NUM,
TCP_PROTOCOL)
ENGINE_WS_RPC_PORT_ID:
shared_utils.new_port_spec(ENGINE_WS_RPC_PORT_NUM, shared_utils.
TCP_PROTOCOL)
}
}
ENTRYPOINT_ARGS = ["sh", "-c"]
ENTRYPOINT_ARGS = ["sh", "-c"]
...
@@ -55,7 +55,7 @@ def launch(
...
@@ -55,7 +55,7 @@ def launch(
existing_el_clients,
existing_el_clients,
extra_params):
extra_params):
log_level = get_client_log_level_or_default(participant_log_level, global_log_level, BESU_LOG_LEVELS)
log_level =
parse_input.
get_client_log_level_or_default(participant_log_level, global_log_level, BESU_LOG_LEVELS)
config = get_config(launcher.network_id, launcher.el_genesis_data,
config = get_config(launcher.network_id, launcher.el_genesis_data,
image, existing_el_clients, log_level, extra_params)
image, existing_el_clients, log_level, extra_params)
...
@@ -65,7 +65,7 @@ def launch(
...
@@ -65,7 +65,7 @@ def launch(
define_fact(service_id = service_id, fact_name = ENODE_FACT_NAME, fact_recipe = struct(method= "POST", endpoint = "", field_extractor = ".result.enode", body = '{"method":"admin_nodeInfo","params":[],"id":1,"jsonrpc":"2.0"}', content_type = "application/json", port_id = RPC_PORT_ID))
define_fact(service_id = service_id, fact_name = ENODE_FACT_NAME, fact_recipe = struct(method= "POST", endpoint = "", field_extractor = ".result.enode", body = '{"method":"admin_nodeInfo","params":[],"id":1,"jsonrpc":"2.0"}', content_type = "application/json", port_id = RPC_PORT_ID))
enode = wait(service_id = service_id, fact_name = ENODE_FACT_NAME)
enode = wait(service_id = service_id, fact_name = ENODE_FACT_NAME)
return new_el_client_context(
return
el_client_context.
new_el_client_context(
"besu",
"besu",
"", # besu has no ENR
"", # besu has no ENR
enode,
enode,
...
@@ -83,8 +83,8 @@ def get_config(network_id, genesis_data, image, existing_el_clients, log_level,
...
@@ -83,8 +83,8 @@ def get_config(network_id, genesis_data, image, existing_el_clients, log_level,
boot_node_1 = existing_el_clients[0]
boot_node_1 = existing_el_clients[0]
boot_node_2 = existing_el_clients[1]
boot_node_2 = existing_el_clients[1]
genesis_json_filepath_on_client = path_join(GENESIS_DATA_DIRPATH_ON_CLIENT_CONTAINER, genesis_data.besu_genesis_json_relative_filepath)
genesis_json_filepath_on_client =
shared_utils.
path_join(GENESIS_DATA_DIRPATH_ON_CLIENT_CONTAINER, genesis_data.besu_genesis_json_relative_filepath)
jwt_secret_json_filepath_on_client = path_join(GENESIS_DATA_DIRPATH_ON_CLIENT_CONTAINER, genesis_data.jwt_secret_relative_filepath)
jwt_secret_json_filepath_on_client =
shared_utils.
path_join(GENESIS_DATA_DIRPATH_ON_CLIENT_CONTAINER, genesis_data.jwt_secret_relative_filepath)
launch_node_command = [
launch_node_command = [
"besu",
"besu",
...
...
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment