refactor!: merge eth-network-package onto eth2-package (#228)

Notes for reviewer - perhaps @leoporoli ?

1. src/el & src/cl & src/node_metrics_info & src/participant.star &
src/participant_network.star & src/prelaunch_data_generator/ &
src/snooper & static_files have just been lifted and shifted
2. constants is just a union of the two
3. ⚠️ parse input is a best effort union of the two; needs some 👀 
4. shared_utils.star is a best effort union of the two
5. package_io, shared_utils etc used to be at root level they have been
shifted
6. eth-network-package has been changed to eth2-package throughout all
`.star` files

Pending after PR - perhaps @leeederek ?
1. Get the README's to make sense together
2. Get the run.gif over here?

⚠️  Note to testers

1. Clone the package
2. Check out this PR
3. Run `kurtosis run .` with args of choice

.circleci/config.yml

@@ -10,9 +10,10 @@ executors:
 
 parameters:
   # To enable/disabled the check_latest_version workflow execution which will be triggered by this scheduled pipeline: https://app.circleci.com/settings/project/github/kurtosis-tech/eth2-package/triggers
+  # TODO revert this - setting this to true to get all existing tests to run on CI during merge
   should-enable-check-latest-version-workflow:
     type: boolean
-    default: false
+    default: true
   # To enable/disabled the check_code workflow execution which will be triggered by the PR's checkers
   should-enable-build-workflow:
     type: boolean

main.star

@@ -2,16 +2,17 @@ parse_input = import_module(
     "github.com/kurtosis-tech/eth2-package/src/package_io/parse_input.star"
 )
 
+participant_network = import_module(
+    "github.com/kurtosis-tech/eth2-package/src/participant_network.star"
+)
+
 static_files = import_module(
     "github.com/kurtosis-tech/eth2-package/src/static_files/static_files.star"
 )
 genesis_constants = import_module(
-    "github.com/kurtosis-tech/eth-network-package/src/prelaunch_data_generator/genesis_constants/genesis_constants.star"
+    "github.com/kurtosis-tech/eth2-package/src/prelaunch_data_generator/genesis_constants/genesis_constants.star"
 )
 
-eth_network_module = import_module(
-    "github.com/kurtosis-tech/eth-network-package/main.star"
-)
 transaction_spammer = import_module(
     "github.com/kurtosis-tech/eth2-package/src/transaction_spammer/transaction_spammer.star"
 )
@@ -66,13 +67,12 @@ PATH_TO_PARSED_BEACON_STATE = "/genesis/output/parsedBeaconState.json"
 
 
 def run(plan, args={}):
-    args_with_right_defaults, args_with_defaults_dict = parse_input.parse_input(
-        plan, args
-    )
+    args_with_right_defaults = parse_input.parse_input(plan, args)
 
     num_participants = len(args_with_right_defaults.participants)
     network_params = args_with_right_defaults.network_params
     mev_params = args_with_right_defaults.mev_params
+    parallel_keystore_generation = args_with_right_defaults.parallel_keystore_generation
 
     grafana_datasource_config_template = read_file(
         static_files.GRAFANA_DATASOURCE_CONFIG_TEMPLATE_FILEPATH
@@ -95,7 +95,20 @@ def run(plan, args={}):
         all_participants,
         cl_genesis_timestamp,
         genesis_validators_root,
-    ) = eth_network_module.run(plan, args_with_defaults_dict)
+    ) = participant_network.launch_participant_network(
+        plan,
+        args_with_right_defaults.participants,
+        network_params,
+        args_with_right_defaults.global_client_log_level,
+        parallel_keystore_generation,
+    )
+
+    plan.print(
+        "NODE JSON RPC URI: '{0}:{1}'".format(
+            all_participants[0].el_client_context.ip_addr,
+            all_participants[0].el_client_context.rpc_port_num,
+        )
+    )
 
     all_el_client_contexts = []
     all_cl_client_contexts = []

src/cl/cl_client_context.star

+def new_cl_client_context(
+    client_name,
+    enr,
+    ip_addr,
+    http_port_num,
+    cl_nodes_metrics_info,
+    beacon_service_name,
+    validator_service_name="",
+    multiaddr="",
+    peer_id="",
+    snooper_enabled=False,
+    snooper_engine_context=None,
+):
+    return struct(
+        client_name=client_name,
+        enr=enr,
+        ip_addr=ip_addr,
+        http_port_num=http_port_num,
+        cl_nodes_metrics_info=cl_nodes_metrics_info,
+        beacon_service_name=beacon_service_name,
+        validator_service_name=validator_service_name,
+        multiaddr=multiaddr,
+        peer_id=peer_id,
+        snooper_enabled=snooper_enabled,
+        snooper_engine_context=snooper_engine_context,
+    )

src/cl/cl_node_ready_conditions.star

+def get_ready_conditions(port_id):
+    recipe = GetHttpRequestRecipe(endpoint="/eth/v1/node/health", port_id=port_id)
+
+    ready_conditions = ReadyCondition(
+        recipe=recipe,
+        field="code",
+        assertion="IN",
+        target_value=[200, 206],
+        timeout="15m",
+    )
+
+    return ready_conditions

src/el/besu/besu_launcher.star

+shared_utils = import_module(
+    "github.com/kurtosis-tech/eth2-package/src/shared_utils/shared_utils.star"
+)
+input_parser = import_module(
+    "github.com/kurtosis-tech/eth2-package/src/package_io/parse_input.star"
+)
+el_client_context = import_module(
+    "github.com/kurtosis-tech/eth2-package/src/el/el_client_context.star"
+)
+el_admin_node_info = import_module(
+    "github.com/kurtosis-tech/eth2-package/src/el/el_admin_node_info.star"
+)
+node_metrics = import_module(
+    "github.com/kurtosis-tech/eth2-package/src/node_metrics_info.star"
+)
+package_io = import_module(
+    "github.com/kurtosis-tech/eth2-package/src/package_io/constants.star"
+)
+
+# The dirpath of the execution data directory on the client container
+EXECUTION_DATA_DIRPATH_ON_CLIENT_CONTAINER = "/opt/besu/execution-data"
+KZG_DATA_DIRPATH_ON_CLIENT_CONTAINER = "/opt/besu/genesis/output/trusted_setup.txt"
+
+GENESIS_DATA_DIRPATH_ON_CLIENT_CONTAINER = "/opt/besu/genesis"
+
+METRICS_PATH = "/metrics"
+
+RPC_PORT_NUM = 8545
+WS_PORT_NUM = 8546
+DISCOVERY_PORT_NUM = 30303
+ENGINE_HTTP_RPC_PORT_NUM = 8551
+METRICS_PORT_NUM = 9001
+
+# The min/max CPU/memory that the execution node can use
+EXECUTION_MIN_CPU = 100
+EXECUTION_MAX_CPU = 1000
+EXECUTION_MIN_MEMORY = 512
+EXECUTION_MAX_MEMORY = 2048
+
+# Port IDs
+RPC_PORT_ID = "rpc"
+WS_PORT_ID = "ws"
+TCP_DISCOVERY_PORT_ID = "tcp-discovery"
+UDP_DISCOVERY_PORT_ID = "udp-discovery"
+ENGINE_HTTP_RPC_PORT_ID = "engine-rpc"
+METRICS_PORT_ID = "metrics"
+
+PRIVATE_IP_ADDRESS_PLACEHOLDER = "KURTOSIS_IP_ADDR_PLACEHOLDER"
+
+USED_PORTS = {
+    RPC_PORT_ID: shared_utils.new_port_spec(RPC_PORT_NUM, shared_utils.TCP_PROTOCOL),
+    WS_PORT_ID: shared_utils.new_port_spec(WS_PORT_NUM, shared_utils.TCP_PROTOCOL),
+    TCP_DISCOVERY_PORT_ID: shared_utils.new_port_spec(
+        DISCOVERY_PORT_NUM, shared_utils.TCP_PROTOCOL
+    ),
+    UDP_DISCOVERY_PORT_ID: shared_utils.new_port_spec(
+        DISCOVERY_PORT_NUM, shared_utils.UDP_PROTOCOL
+    ),
+    ENGINE_HTTP_RPC_PORT_ID: shared_utils.new_port_spec(
+        ENGINE_HTTP_RPC_PORT_NUM, shared_utils.TCP_PROTOCOL
+    ),
+    METRICS_PORT_ID: shared_utils.new_port_spec(
+        METRICS_PORT_NUM, shared_utils.TCP_PROTOCOL
+    ),
+}
+
+ENTRYPOINT_ARGS = ["sh", "-c"]
+
+BESU_LOG_LEVELS = {
+    package_io.GLOBAL_CLIENT_LOG_LEVEL.error: "ERROR",
+    package_io.GLOBAL_CLIENT_LOG_LEVEL.warn: "WARN",
+    package_io.GLOBAL_CLIENT_LOG_LEVEL.info: "INFO",
+    package_io.GLOBAL_CLIENT_LOG_LEVEL.debug: "DEBUG",
+    package_io.GLOBAL_CLIENT_LOG_LEVEL.trace: "TRACE",
+}
+
+
+def launch(
+    plan,
+    launcher,
+    service_name,
+    image,
+    participant_log_level,
+    global_log_level,
+    existing_el_clients,
+    el_min_cpu,
+    el_max_cpu,
+    el_min_mem,
+    el_max_mem,
+    extra_params,
+    extra_env_vars,
+):
+    log_level = input_parser.get_client_log_level_or_default(
+        participant_log_level, global_log_level, BESU_LOG_LEVELS
+    )
+
+    el_min_cpu = int(el_min_cpu) if int(el_min_cpu) > 0 else EXECUTION_MIN_CPU
+    el_max_cpu = int(el_max_cpu) if int(el_max_cpu) > 0 else EXECUTION_MAX_CPU
+    el_min_mem = int(el_min_mem) if int(el_min_mem) > 0 else EXECUTION_MIN_MEMORY
+    el_max_mem = int(el_max_mem) if int(el_max_mem) > 0 else EXECUTION_MAX_MEMORY
+
+    config, jwt_secret_json_filepath_on_client = get_config(
+        launcher.network_id,
+        launcher.el_genesis_data,
+        image,
+        existing_el_clients,
+        log_level,
+        el_min_cpu,
+        el_max_cpu,
+        el_min_mem,
+        el_max_mem,
+        extra_params,
+        extra_env_vars,
+    )
+
+    service = plan.add_service(service_name, config)
+
+    enode = el_admin_node_info.get_enode_for_node(plan, service_name, RPC_PORT_ID)
+
+    jwt_secret = shared_utils.read_file_from_service(
+        plan, service_name, jwt_secret_json_filepath_on_client
+    )
+
+    metrics_url = "{0}:{1}".format(service.ip_address, METRICS_PORT_NUM)
+    besu_metrics_info = node_metrics.new_node_metrics_info(
+        service_name, METRICS_PATH, metrics_url
+    )
+
+    return el_client_context.new_el_client_context(
+        "besu",
+        "",  # besu has no ENR
+        enode,
+        service.ip_address,
+        RPC_PORT_NUM,
+        WS_PORT_NUM,
+        ENGINE_HTTP_RPC_PORT_NUM,
+        jwt_secret,
+        service_name,
+        [besu_metrics_info],
+    )
+
+
+def get_config(
+    network_id,
+    genesis_data,
+    image,
+    existing_el_clients,
+    log_level,
+    el_min_cpu,
+    el_max_cpu,
+    el_min_mem,
+    el_max_mem,
+    extra_params,
+    extra_env_vars,
+):
+    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 = shared_utils.path_join(
+        GENESIS_DATA_DIRPATH_ON_CLIENT_CONTAINER,
+        genesis_data.jwt_secret_relative_filepath,
+    )
+
+    cmd = [
+        "besu",
+        "--logging=" + log_level,
+        "--data-path=" + EXECUTION_DATA_DIRPATH_ON_CLIENT_CONTAINER,
+        "--genesis-file=" + genesis_json_filepath_on_client,
+        "--network-id=" + network_id,
+        "--host-allowlist=*",
+        "--rpc-http-enabled=true",
+        "--rpc-http-host=0.0.0.0",
+        "--rpc-http-port={0}".format(RPC_PORT_NUM),
+        "--rpc-http-api=ADMIN,CLIQUE,ETH,NET,DEBUG,TXPOOL,ENGINE,TRACE,WEB3",
+        "--rpc-http-cors-origins=*",
+        "--rpc-ws-enabled=true",
+        "--rpc-ws-host=0.0.0.0",
+        "--rpc-ws-port={0}".format(WS_PORT_NUM),
+        "--rpc-ws-api=ADMIN,CLIQUE,ETH,NET,DEBUG,TXPOOL,ENGINE,TRACE,WEB3",
+        "--p2p-enabled=true",
+        "--p2p-host=" + PRIVATE_IP_ADDRESS_PLACEHOLDER,
+        "--p2p-port={0}".format(DISCOVERY_PORT_NUM),
+        "--engine-rpc-enabled=true",
+        "--engine-jwt-secret={0}".format(jwt_secret_json_filepath_on_client),
+        "--engine-host-allowlist=*",
+        "--engine-rpc-port={0}".format(ENGINE_HTTP_RPC_PORT_NUM),
+        "--sync-mode=FULL",
+        "--data-storage-format=BONSAI",
+        "--kzg-trusted-setup=" + KZG_DATA_DIRPATH_ON_CLIENT_CONTAINER,
+        "--metrics-enabled=true",
+        "--metrics-host=0.0.0.0",
+        "--metrics-port={0}".format(METRICS_PORT_NUM),
+    ]
+
+    if len(existing_el_clients) > 0:
+        cmd.append(
+            "--bootnodes="
+            + ",".join(
+                [
+                    ctx.enode
+                    for ctx in existing_el_clients[: package_io.MAX_ENODE_ENTRIES]
+                ]
+            )
+        )
+
+    if len(extra_params) > 0:
+        # we do this as extra_params isn't a normal [] but a proto repeated array
+        cmd.extend([param for param in extra_params])
+
+    cmd_str = " ".join(cmd)
+
+    return (
+        ServiceConfig(
+            image=image,
+            ports=USED_PORTS,
+            cmd=[cmd_str],
+            files={
+                GENESIS_DATA_DIRPATH_ON_CLIENT_CONTAINER: genesis_data.files_artifact_uuid
+            },
+            entrypoint=ENTRYPOINT_ARGS,
+            private_ip_address_placeholder=PRIVATE_IP_ADDRESS_PLACEHOLDER,
+            min_cpu=el_min_cpu,
+            max_cpu=el_max_cpu,
+            min_memory=el_min_mem,
+            max_memory=el_max_mem,
+            env_vars=extra_env_vars,
+        ),
+        jwt_secret_json_filepath_on_client,
+    )
+
+
+def new_besu_launcher(network_id, el_genesis_data):
+    return struct(network_id=network_id, el_genesis_data=el_genesis_data)

src/el/el_admin_node_info.star

+def get_enode_enr_for_node(plan, service_name, port_id):
+    recipe = PostHttpRequestRecipe(
+        endpoint="",
+        body='{"method":"admin_nodeInfo","params":[],"id":1,"jsonrpc":"2.0"}',
+        content_type="application/json",
+        port_id=port_id,
+        extract={
+            "enode": """.result.enode | split("?") | .[0]""",
+            "enr": ".result.enr",
+        },
+    )
+    response = plan.wait(
+        recipe=recipe,
+        field="extract.enode",
+        assertion="!=",
+        target_value="",
+        timeout="15m",
+        service_name=service_name,
+    )
+    return (response["extract.enode"], response["extract.enr"])
+
+
+def get_enode_for_node(plan, service_name, port_id):
+    recipe = PostHttpRequestRecipe(
+        endpoint="",
+        body='{"method":"admin_nodeInfo","params":[],"id":1,"jsonrpc":"2.0"}',
+        content_type="application/json",
+        port_id=port_id,
+        extract={
+            "enode": """.result.enode | split("?") | .[0]""",
+        },
+    )
+    response = plan.wait(
+        recipe=recipe,
+        field="extract.enode",
+        assertion="!=",
+        target_value="",
+        timeout="15m",
+        service_name=service_name,
+    )
+    return response["extract.enode"]

src/el/el_client_context.star

+def new_el_client_context(
+    client_name,
+    enr,
+    enode,
+    ip_addr,
+    rpc_port_num,
+    ws_port_num,
+    engine_rpc_port_num,
+    jwt_secret,
+    service_name="",
+    el_metrics_info=None,
+):
+    return struct(
+        service_name=service_name,
+        client_name=client_name,
+        enr=enr,
+        enode=enode,
+        ip_addr=ip_addr,
+        rpc_port_num=rpc_port_num,
+        ws_port_num=ws_port_num,
+        engine_rpc_port_num=engine_rpc_port_num,
+        jwt_secret=jwt_secret,
+        el_metrics_info=el_metrics_info,
+    )

src/el/erigon/erigon_launcher.star

+shared_utils = import_module(
+    "github.com/kurtosis-tech/eth2-package/src/shared_utils/shared_utils.star"
+)
+input_parser = import_module(
+    "github.com/kurtosis-tech/eth2-package/src/package_io/parse_input.star"
+)
+el_admin_node_info = import_module(
+    "github.com/kurtosis-tech/eth2-package/src/el/el_admin_node_info.star"
+)
+el_client_context = import_module(
+    "github.com/kurtosis-tech/eth2-package/src/el/el_client_context.star"
+)
+
+node_metrics = import_module(
+    "github.com/kurtosis-tech/eth2-package/src/node_metrics_info.star"
+)
+package_io = import_module(
+    "github.com/kurtosis-tech/eth2-package/src/package_io/constants.star"
+)
+
+# The dirpath of the execution data directory on the client container
+EXECUTION_DATA_DIRPATH_ON_CLIENT_CONTAINER = "/home/erigon/execution-data"
+
+GENESIS_DATA_MOUNT_DIRPATH = "/genesis"
+
+METRICS_PATH = "/metrics"
+
+WS_RPC_PORT_NUM = 8545
+DISCOVERY_PORT_NUM = 30303
+ENGINE_RPC_PORT_NUM = 8551
+METRICS_PORT_NUM = 9001
+
+# The min/max CPU/memory that the execution node can use
+EXECUTION_MIN_CPU = 100
+EXECUTION_MAX_CPU = 1000
+EXECUTION_MIN_MEMORY = 512
+EXECUTION_MAX_MEMORY = 2048
+
+# Port IDs
+WS_RPC_PORT_ID = "ws-rpc"
+TCP_DISCOVERY_PORT_ID = "tcp-discovery"
+UDP_DISCOVERY_PORT_ID = "udp-discovery"
+ENGINE_RPC_PORT_ID = "engine-rpc"
+METRICS_PORT_ID = "metrics"
+
+
+PRIVATE_IP_ADDRESS_PLACEHOLDER = "KURTOSIS_IP_ADDR_PLACEHOLDER"
+
+USED_PORTS = {
+    WS_RPC_PORT_ID: shared_utils.new_port_spec(
+        WS_RPC_PORT_NUM, shared_utils.TCP_PROTOCOL
+    ),
+    TCP_DISCOVERY_PORT_ID: shared_utils.new_port_spec(
+        DISCOVERY_PORT_NUM, shared_utils.TCP_PROTOCOL
+    ),
+    UDP_DISCOVERY_PORT_ID: shared_utils.new_port_spec(
+        DISCOVERY_PORT_NUM, shared_utils.UDP_PROTOCOL
+    ),
+    ENGINE_RPC_PORT_ID: shared_utils.new_port_spec(
+        ENGINE_RPC_PORT_NUM, shared_utils.TCP_PROTOCOL
+    ),
+    METRICS_PORT_ID: shared_utils.new_port_spec(
+        METRICS_PORT_NUM, shared_utils.TCP_PROTOCOL
+    ),
+}
+
+ENTRYPOINT_ARGS = ["sh", "-c"]
+
+ERIGON_LOG_LEVELS = {
+    package_io.GLOBAL_CLIENT_LOG_LEVEL.error: "1",
+    package_io.GLOBAL_CLIENT_LOG_LEVEL.warn: "2",
+    package_io.GLOBAL_CLIENT_LOG_LEVEL.info: "3",
+    package_io.GLOBAL_CLIENT_LOG_LEVEL.debug: "4",
+    package_io.GLOBAL_CLIENT_LOG_LEVEL.trace: "5",
+}
+
+
+def launch(
+    plan,
+    launcher,
+    service_name,
+    image,
+    participant_log_level,
+    global_log_level,
+    existing_el_clients,
+    el_min_cpu,
+    el_max_cpu,
+    el_min_mem,
+    el_max_mem,
+    extra_params,
+    extra_env_vars,
+):
+    log_level = input_parser.get_client_log_level_or_default(
+        participant_log_level, global_log_level, ERIGON_LOG_LEVELS
+    )
+
+    el_min_cpu = el_min_cpu if int(el_min_cpu) > 0 else EXECUTION_MIN_CPU
+    el_max_cpu = el_max_cpu if int(el_max_cpu) > 0 else EXECUTION_MAX_CPU
+    el_min_mem = el_min_mem if int(el_min_mem) > 0 else EXECUTION_MIN_MEMORY
+    el_max_mem = el_max_mem if int(el_max_mem) > 0 else EXECUTION_MAX_MEMORY
+
+    config, jwt_secret_json_filepath_on_client = get_config(
+        launcher.network_id,
+        launcher.el_genesis_data,
+        image,
+        existing_el_clients,
+        log_level,
+        el_min_cpu,
+        el_max_cpu,
+        el_min_mem,
+        el_max_mem,
+        extra_params,
+        extra_env_vars,
+    )
+
+    service = plan.add_service(service_name, config)
+
+    enode, enr = el_admin_node_info.get_enode_enr_for_node(
+        plan, service_name, WS_RPC_PORT_ID
+    )
+
+    jwt_secret = shared_utils.read_file_from_service(
+        plan, service_name, jwt_secret_json_filepath_on_client
+    )
+
+    metrics_url = "{0}:{1}".format(service.ip_address, METRICS_PORT_NUM)
+    erigon_metrics_info = node_metrics.new_node_metrics_info(
+        service_name, METRICS_PATH, metrics_url
+    )
+
+    return el_client_context.new_el_client_context(
+        "erigon",
+        enr,
+        enode,
+        service.ip_address,
+        WS_RPC_PORT_NUM,
+        WS_RPC_PORT_NUM,
+        ENGINE_RPC_PORT_NUM,
+        jwt_secret,
+        service_name,
+        [erigon_metrics_info],
+    )
+
+
+def get_config(
+    network_id,
+    genesis_data,
+    image,
+    existing_el_clients,
+    verbosity_level,
+    el_min_cpu,
+    el_max_cpu,
+    el_min_mem,
+    el_max_mem,
+    extra_params,
+    extra_env_vars,
+):
+    network_id = network_id
+
+    genesis_json_filepath_on_client = shared_utils.path_join(
+        GENESIS_DATA_MOUNT_DIRPATH, genesis_data.erigon_genesis_json_relative_filepath
+    )
+    jwt_secret_json_filepath_on_client = shared_utils.path_join(
+        GENESIS_DATA_MOUNT_DIRPATH, genesis_data.jwt_secret_relative_filepath
+    )
+
+    init_datadir_cmd_str = "erigon init --datadir={0} {1}".format(
+        EXECUTION_DATA_DIRPATH_ON_CLIENT_CONTAINER,
+        genesis_json_filepath_on_client,
+    )
+
+    # TODO remove this based on https://github.com/kurtosis-tech/eth2-merge-kurtosis-module/issues/152
+    if len(existing_el_clients) == 0:
+        fail("Erigon needs at least one node to exist, which it treats as the bootnode")
+
+    boot_node_1 = existing_el_clients[0]
+
+    cmd = [
+        "erigon",
+        "--log.console.verbosity=" + verbosity_level,
+        "--datadir=" + EXECUTION_DATA_DIRPATH_ON_CLIENT_CONTAINER,
+        "--port={0}".format(DISCOVERY_PORT_NUM),
+        "--networkid=" + network_id,
+        "--http.api=eth,erigon,engine,web3,net,debug,trace,txpool,admin",
+        "--http.vhosts=*",
+        "--ws",
+        "--allow-insecure-unlock",
+        "--nat=extip:" + PRIVATE_IP_ADDRESS_PLACEHOLDER,
+        "--http",
+        "--http.addr=0.0.0.0",
+        "--http.corsdomain=*",
+        "--http.port={0}".format(WS_RPC_PORT_NUM),
+        "--authrpc.jwtsecret={0}".format(jwt_secret_json_filepath_on_client),
+        "--authrpc.addr=0.0.0.0",
+        "--authrpc.port={0}".format(ENGINE_RPC_PORT_NUM),
+        "--authrpc.vhosts=*",
+        "--metrics",
+        "--metrics.addr=0.0.0.0",
+        "--metrics.port={0}".format(METRICS_PORT_NUM),
+    ]
+
+    if len(existing_el_clients) > 0:
+        cmd.append(
+            "--bootnodes="
+            + ",".join(
+                [
+                    ctx.enode
+                    for ctx in existing_el_clients[: package_io.MAX_ENODE_ENTRIES]
+                ]
+            )
+        )
+        cmd.append(
+            "--staticpeers="
+            + ",".join(
+                [
+                    ctx.enode
+                    for ctx in existing_el_clients[: package_io.MAX_ENODE_ENTRIES]
+                ]
+            )
+        )
+
+    if len(extra_params) > 0:
+        # this is a repeated<proto type>, we convert it into Starlark
+        cmd.extend([param for param in extra_params])
+
+    command_arg = [init_datadir_cmd_str, " ".join(cmd)]
+
+    command_arg_str = " && ".join(command_arg)
+
+    return (
+        ServiceConfig(
+            image=image,
+            ports=USED_PORTS,
+            cmd=[command_arg_str],
+            files={GENESIS_DATA_MOUNT_DIRPATH: genesis_data.files_artifact_uuid},
+            entrypoint=ENTRYPOINT_ARGS,
+            private_ip_address_placeholder=PRIVATE_IP_ADDRESS_PLACEHOLDER,
+            min_cpu=el_min_cpu,
+            max_cpu=el_max_cpu,
+            min_memory=el_min_mem,
+            max_memory=el_max_mem,
+            env_vars=extra_env_vars,
+        ),
+        jwt_secret_json_filepath_on_client,
+    )
+
+
+def new_erigon_launcher(network_id, el_genesis_data):
+    return struct(
+        network_id=network_id,
+        el_genesis_data=el_genesis_data,
+    )

src/el/ethereumjs/ethereumjs_launcher.star

+shared_utils = import_module(
+    "github.com/kurtosis-tech/eth2-package/src/shared_utils/shared_utils.star"
+)
+input_parser = import_module(
+    "github.com/kurtosis-tech/eth2-package/src/package_io/parse_input.star"
+)
+el_client_context = import_module(
+    "github.com/kurtosis-tech/eth2-package/src/el/el_client_context.star"
+)
+el_admin_node_info = import_module(
+    "github.com/kurtosis-tech/eth2-package/src/el/el_admin_node_info.star"
+)
+
+node_metrics = import_module(
+    "github.com/kurtosis-tech/eth2-package/src/node_metrics_info.star"
+)
+package_io = import_module(
+    "github.com/kurtosis-tech/eth2-package/src/package_io/constants.star"
+)
+
+
+RPC_PORT_NUM = 8545
+WS_PORT_NUM = 8546
+WS_PORT_ENGINE_NUM = 8547
+DISCOVERY_PORT_NUM = 30303
+ENGINE_RPC_PORT_NUM = 8551
+METRICS_PORT_NUM = 9001
+
+# The min/max CPU/memory that the execution node can use
+EXECUTION_MIN_CPU = 100
+EXECUTION_MAX_CPU = 1000
+EXECUTION_MIN_MEMORY = 256
+EXECUTION_MAX_MEMORY = 1024
+
+# Port IDs
+RPC_PORT_ID = "rpc"
+WS_PORT_ID = "ws"
+TCP_DISCOVERY_PORT_ID = "tcp-discovery"
+UDP_DISCOVERY_PORT_ID = "udp-discovery"
+ENGINE_RPC_PORT_ID = "engine-rpc"
+WS_PORT_ENGINE_ID = "ws-engine"
+METRICS_PORT_ID = "metrics"
+
+GENESIS_DATA_MOUNT_DIRPATH = "/genesis"
+
+PREFUNDED_KEYS_MOUNT_DIRPATH = "/prefunded-keys"
+
+METRICS_PATH = "/metrics"
+
+# The dirpath of the execution data directory on the client container
+EXECUTION_DATA_DIRPATH_ON_CLIENT_CONTAINER = "/execution-data"
+
+PRIVATE_IP_ADDRESS_PLACEHOLDER = "KURTOSIS_IP_ADDR_PLACEHOLDER"
+
+USED_PORTS = {
+    RPC_PORT_ID: shared_utils.new_port_spec(RPC_PORT_NUM, shared_utils.TCP_PROTOCOL),
+    WS_PORT_ID: shared_utils.new_port_spec(WS_PORT_NUM, shared_utils.TCP_PROTOCOL),
+    WS_PORT_ENGINE_ID: shared_utils.new_port_spec(
+        WS_PORT_ENGINE_NUM, shared_utils.TCP_PROTOCOL
+    ),
+    TCP_DISCOVERY_PORT_ID: shared_utils.new_port_spec(
+        DISCOVERY_PORT_NUM, shared_utils.TCP_PROTOCOL
+    ),
+    UDP_DISCOVERY_PORT_ID: shared_utils.new_port_spec(
+        DISCOVERY_PORT_NUM, shared_utils.UDP_PROTOCOL
+    ),
+    ENGINE_RPC_PORT_ID: shared_utils.new_port_spec(
+        ENGINE_RPC_PORT_NUM, shared_utils.TCP_PROTOCOL
+    ),
+    # METRICS_PORT_ID: shared_utils.new_port_spec(METRICS_PORT_NUM, shared_utils.TCP_PROTOCOL)
+}
+
+ENTRYPOINT_ARGS = []
+
+VERBOSITY_LEVELS = {
+    package_io.GLOBAL_CLIENT_LOG_LEVEL.error: "error",
+    package_io.GLOBAL_CLIENT_LOG_LEVEL.warn: "warn",
+    package_io.GLOBAL_CLIENT_LOG_LEVEL.info: "info",
+    package_io.GLOBAL_CLIENT_LOG_LEVEL.debug: "debug",
+    package_io.GLOBAL_CLIENT_LOG_LEVEL.trace: "trace",
+}
+
+
+def launch(
+    plan,
+    launcher,
+    service_name,
+    image,
+    participant_log_level,
+    global_log_level,
+    # If empty then the node will be launched as a bootnode
+    existing_el_clients,
+    el_min_cpu,
+    el_max_cpu,
+    el_min_mem,
+    el_max_mem,
+    extra_params,
+    extra_env_vars,
+):
+    log_level = input_parser.get_client_log_level_or_default(
+        participant_log_level, global_log_level, VERBOSITY_LEVELS
+    )
+
+    el_min_cpu = el_min_cpu if int(el_min_cpu) > 0 else EXECUTION_MIN_CPU
+    el_max_cpu = el_max_cpu if int(el_max_cpu) > 0 else EXECUTION_MAX_CPU
+    el_min_mem = el_min_mem if int(el_min_mem) > 0 else EXECUTION_MIN_MEMORY
+    el_max_mem = el_max_mem if int(el_max_mem) > 0 else EXECUTION_MAX_MEMORY
+
+    config, jwt_secret_json_filepath_on_client = get_config(
+        launcher.el_genesis_data,
+        image,
+        existing_el_clients,
+        log_level,
+        el_min_cpu,
+        el_max_cpu,
+        el_min_mem,
+        el_max_mem,
+        extra_params,
+        extra_env_vars,
+    )
+
+    service = plan.add_service(service_name, config)
+
+    enode = el_admin_node_info.get_enode_for_node(plan, service_name, RPC_PORT_ID)
+
+    jwt_secret = shared_utils.read_file_from_service(
+        plan, service_name, jwt_secret_json_filepath_on_client
+    )
+
+    # TODO: Passing empty string for metrics_url for now https://github.com/kurtosis-tech/eth2-package/issues/127
+    # metrics_url = "http://{0}:{1}".format(service.ip_address, METRICS_PORT_NUM)
+    ethjs_metrics_info = None
+
+    return el_client_context.new_el_client_context(
+        "ethereumjs",
+        "",  # ethereumjs has no enr
+        enode,
+        service.ip_address,
+        RPC_PORT_NUM,
+        WS_PORT_NUM,
+        ENGINE_RPC_PORT_NUM,
+        jwt_secret,
+        service_name,
+        [ethjs_metrics_info],
+    )
+
+
+def get_config(
+    genesis_data,
+    image,
+    existing_el_clients,
+    verbosity_level,
+    el_min_cpu,
+    el_max_cpu,
+    el_min_mem,
+    el_max_mem,
+    extra_params,
+    extra_env_vars,
+):
+    genesis_json_filepath_on_client = shared_utils.path_join(
+        GENESIS_DATA_MOUNT_DIRPATH, genesis_data.geth_genesis_json_relative_filepath
+    )
+    jwt_secret_json_filepath_on_client = shared_utils.path_join(
+        GENESIS_DATA_MOUNT_DIRPATH, genesis_data.jwt_secret_relative_filepath
+    )
+
+    cmd = [
+        "--gethGenesis=" + genesis_json_filepath_on_client,
+        "--dataDir=" + EXECUTION_DATA_DIRPATH_ON_CLIENT_CONTAINER,
+        "--port={0}".format(DISCOVERY_PORT_NUM),
+        "--rpc",
+        "--rpcAddr=0.0.0.0",
+        "--rpcPort={0}".format(RPC_PORT_NUM),
+        "--rpcCors=*",
+        "--rpcEngine",
+        "--rpcEngineAddr=0.0.0.0",
+        "--rpcEnginePort={0}".format(ENGINE_RPC_PORT_NUM),
+        "--ws",
+        "--wsAddr=0.0.0.0",
+        "--wsPort={0}".format(WS_PORT_NUM),
+        "--wsEnginePort={0}".format(WS_PORT_ENGINE_NUM),
+        "--wsEngineAddr=0.0.0.0",
+        "--jwt-secret={0}".format(jwt_secret_json_filepath_on_client),
+        "--extIP={0}".format(PRIVATE_IP_ADDRESS_PLACEHOLDER),
+        "--sync=full",
+        "--isSingleNode=true",
+        "--logLevel={0}".format(verbosity_level),
+    ]
+
+    if len(existing_el_clients) > 0:
+        cmd.append(
+            "--bootnodes="
+            + ",".join(
+                [
+                    ctx.enode
+                    for ctx in existing_el_clients[: package_io.MAX_ENODE_ENTRIES]
+                ]
+            )
+        )
+
+    if len(extra_params) > 0:
+        # this is a repeated<proto type>, we convert it into Starlark
+        cmd.extend([param for param in extra_params])
+
+    return (
+        ServiceConfig(
+            image=image,
+            ports=USED_PORTS,
+            cmd=cmd,
+            files={
+                GENESIS_DATA_MOUNT_DIRPATH: genesis_data.files_artifact_uuid,
+            },
+            entrypoint=ENTRYPOINT_ARGS,
+            private_ip_address_placeholder=PRIVATE_IP_ADDRESS_PLACEHOLDER,
+            min_cpu=el_min_cpu,
+            max_cpu=el_max_cpu,
+            min_memory=el_min_mem,
+            max_memory=el_max_mem,
+            env_vars=extra_env_vars,
+        ),
+        jwt_secret_json_filepath_on_client,
+    )
+
+
+def new_ethereumjs_launcher(el_genesis_data):
+    return struct(
+        el_genesis_data=el_genesis_data,
+    )

src/el/nethermind/nethermind_launcher.star

+shared_utils = import_module(
+    "github.com/kurtosis-tech/eth2-package/src/shared_utils/shared_utils.star"
+)
+input_parser = import_module(
+    "github.com/kurtosis-tech/eth2-package/src/package_io/parse_input.star"
+)
+el_client_context = import_module(
+    "github.com/kurtosis-tech/eth2-package/src/el/el_client_context.star"
+)
+el_admin_node_info = import_module(
+    "github.com/kurtosis-tech/eth2-package/src/el/el_admin_node_info.star"
+)
+
+node_metrics = import_module(
+    "github.com/kurtosis-tech/eth2-package/src/node_metrics_info.star"
+)
+package_io = import_module(
+    "github.com/kurtosis-tech/eth2-package/src/package_io/constants.star"
+)
+
+# The dirpath of the execution data directory on the client container
+EXECUTION_DATA_DIRPATH_ON_CLIENT_CONTAINER = "/execution-data"
+KZG_DATA_DIRPATH_ON_CLIENT_CONTAINER = "/genesis/output/trusted_setup.txt"
+GENESIS_DATA_MOUNT_DIRPATH = "/genesis"
+
+METRICS_PATH = "/metrics"
+
+RPC_PORT_NUM = 8545
+WS_PORT_NUM = 8546
+DISCOVERY_PORT_NUM = 30303
+ENGINE_RPC_PORT_NUM = 8551
+METRICS_PORT_NUM = 9001
+
+# The min/max CPU/memory that the execution node can use
+EXECUTION_MIN_CPU = 100
+EXECUTION_MAX_CPU = 1000
+EXECUTION_MIN_MEMORY = 512
+EXECUTION_MAX_MEMORY = 2048
+
+# Port IDs
+RPC_PORT_ID = "rpc"
+WS_PORT_ID = "ws"
+TCP_DISCOVERY_PORT_ID = "tcp-discovery"
+UDP_DISCOVERY_PORT_ID = "udp-discovery"
+ENGINE_RPC_PORT_ID = "engine-rpc"
+METRICS_PORT_ID = "metrics"
+
+PRIVATE_IP_ADDRESS_PLACEHOLDER = "KURTOSIS_IP_ADDR_PLACEHOLDER"
+
+USED_PORTS = {
+    RPC_PORT_ID: shared_utils.new_port_spec(RPC_PORT_NUM, shared_utils.TCP_PROTOCOL),
+    WS_PORT_ID: shared_utils.new_port_spec(WS_PORT_NUM, shared_utils.TCP_PROTOCOL),
+    TCP_DISCOVERY_PORT_ID: shared_utils.new_port_spec(
+        DISCOVERY_PORT_NUM, shared_utils.TCP_PROTOCOL
+    ),
+    UDP_DISCOVERY_PORT_ID: shared_utils.new_port_spec(
+        DISCOVERY_PORT_NUM, shared_utils.UDP_PROTOCOL
+    ),
+    ENGINE_RPC_PORT_ID: shared_utils.new_port_spec(
+        ENGINE_RPC_PORT_NUM, shared_utils.TCP_PROTOCOL
+    ),
+    METRICS_PORT_ID: shared_utils.new_port_spec(
+        METRICS_PORT_NUM, shared_utils.TCP_PROTOCOL
+    ),
+}
+
+NETHERMIND_LOG_LEVELS = {
+    package_io.GLOBAL_CLIENT_LOG_LEVEL.error: "ERROR",
+    package_io.GLOBAL_CLIENT_LOG_LEVEL.warn: "WARN",
+    package_io.GLOBAL_CLIENT_LOG_LEVEL.info: "INFO",
+    package_io.GLOBAL_CLIENT_LOG_LEVEL.debug: "DEBUG",
+    package_io.GLOBAL_CLIENT_LOG_LEVEL.trace: "TRACE",
+}
+
+
+def launch(
+    plan,
+    launcher,
+    service_name,
+    image,
+    participant_log_level,
+    global_log_level,
+    existing_el_clients,
+    el_min_cpu,
+    el_max_cpu,
+    el_min_mem,
+    el_max_mem,
+    extra_params,
+    extra_env_vars,
+):
+    log_level = input_parser.get_client_log_level_or_default(
+        participant_log_level, global_log_level, NETHERMIND_LOG_LEVELS
+    )
+
+    el_min_cpu = el_min_cpu if int(el_min_cpu) > 0 else EXECUTION_MIN_CPU
+    el_max_cpu = el_max_cpu if int(el_max_cpu) > 0 else EXECUTION_MAX_CPU
+    el_min_mem = el_min_mem if int(el_min_mem) > 0 else EXECUTION_MIN_MEMORY
+    el_max_mem = el_max_mem if int(el_max_mem) > 0 else EXECUTION_MAX_MEMORY
+
+    config, jwt_secret_json_filepath_on_client = get_config(
+        launcher.el_genesis_data,
+        image,
+        existing_el_clients,
+        log_level,
+        el_min_cpu,
+        el_max_cpu,
+        el_min_mem,
+        el_max_mem,
+        extra_params,
+        extra_env_vars,
+    )
+
+    service = plan.add_service(service_name, config)
+
+    enode = el_admin_node_info.get_enode_for_node(plan, service_name, RPC_PORT_ID)
+
+    jwt_secret = shared_utils.read_file_from_service(
+        plan, service_name, jwt_secret_json_filepath_on_client
+    )
+
+    metrics_url = "{0}:{1}".format(service.ip_address, METRICS_PORT_NUM)
+    nethermind_metrics_info = node_metrics.new_node_metrics_info(
+        service_name, METRICS_PATH, metrics_url
+    )
+
+    return el_client_context.new_el_client_context(
+        "nethermind",
+        "",  # nethermind has no ENR in the eth2-merge-kurtosis-module either
+        # Nethermind node info endpoint doesn't return ENR field https://docs.nethermind.io/nethermind/ethereum-client/json-rpc/admin
+        enode,
+        service.ip_address,
+        RPC_PORT_NUM,
+        WS_PORT_NUM,
+        ENGINE_RPC_PORT_NUM,
+        jwt_secret,
+        service_name,
+        [nethermind_metrics_info],
+    )
+
+
+def get_config(
+    genesis_data,
+    image,
+    existing_el_clients,
+    log_level,
+    el_min_cpu,
+    el_max_cpu,
+    el_min_mem,
+    el_max_mem,
+    extra_params,
+    extra_env_vars,
+):
+    genesis_json_filepath_on_client = shared_utils.path_join(
+        GENESIS_DATA_MOUNT_DIRPATH,
+        genesis_data.nethermind_genesis_json_relative_filepath,
+    )
+    jwt_secret_json_filepath_on_client = shared_utils.path_join(
+        GENESIS_DATA_MOUNT_DIRPATH, genesis_data.jwt_secret_relative_filepath
+    )
+
+    cmd = [
+        "--log=" + log_level,
+        "--datadir=" + EXECUTION_DATA_DIRPATH_ON_CLIENT_CONTAINER,
+        "--Init.ChainSpecPath=" + genesis_json_filepath_on_client,
+        "--Init.WebSocketsEnabled=true",
+        "--Init.KzgSetupPath=" + KZG_DATA_DIRPATH_ON_CLIENT_CONTAINER,
+        "--config=none.cfg",
+        "--JsonRpc.Enabled=true",
+        "--JsonRpc.EnabledModules=net,eth,consensus,subscribe,web3,admin",
+        "--JsonRpc.Host=0.0.0.0",
+        "--JsonRpc.Port={0}".format(RPC_PORT_NUM),
+        "--JsonRpc.WebSocketsPort={0}".format(WS_PORT_NUM),
+        "--JsonRpc.EngineHost=0.0.0.0",
+        "--JsonRpc.EnginePort={0}".format(ENGINE_RPC_PORT_NUM),
+        "--Network.ExternalIp={0}".format(PRIVATE_IP_ADDRESS_PLACEHOLDER),
+        "--Network.DiscoveryPort={0}".format(DISCOVERY_PORT_NUM),
+        "--Network.P2PPort={0}".format(DISCOVERY_PORT_NUM),
+        "--JsonRpc.JwtSecretFile={0}".format(jwt_secret_json_filepath_on_client),
+        "--Network.OnlyStaticPeers=true",
+        "--Metrics.Enabled=true",
+        "--Metrics.ExposePort={0}".format(METRICS_PORT_NUM),
+    ]
+
+    if len(existing_el_clients) > 0:
+        cmd.append(
+            "--Network.StaticPeers="
+            + ",".join(
+                [
+                    ctx.enode
+                    for ctx in existing_el_clients[: package_io.MAX_ENODE_ENTRIES]
+                ]
+            )
+        )
+
+    if len(extra_params) > 0:
+        # this is a repeated<proto type>, we convert it into Starlark
+        cmd.extend([param for param in extra_params])
+
+    return (
+        ServiceConfig(
+            image=image,
+            ports=USED_PORTS,
+            cmd=cmd,
+            files={
+                GENESIS_DATA_MOUNT_DIRPATH: genesis_data.files_artifact_uuid,
+            },
+            private_ip_address_placeholder=PRIVATE_IP_ADDRESS_PLACEHOLDER,
+            min_cpu=el_min_cpu,
+            max_cpu=el_max_cpu,
+            min_memory=el_min_mem,
+            max_memory=el_max_mem,
+            env_vars=extra_env_vars,
+        ),
+        jwt_secret_json_filepath_on_client,
+    )
+
+
+def new_nethermind_launcher(el_genesis_data):
+    return struct(el_genesis_data=el_genesis_data)

src/el/reth/reth_launcher.star

+shared_utils = import_module(
+    "github.com/kurtosis-tech/eth2-package/src/shared_utils/shared_utils.star"
+)
+input_parser = import_module(
+    "github.com/kurtosis-tech/eth2-package/src/package_io/parse_input.star"
+)
+el_client_context = import_module(
+    "github.com/kurtosis-tech/eth2-package/src/el/el_client_context.star"
+)
+el_admin_node_info = import_module(
+    "github.com/kurtosis-tech/eth2-package/src/el/el_admin_node_info.star"
+)
+node_metrics = import_module(
+    "github.com/kurtosis-tech/eth2-package/src/node_metrics_info.star"
+)
+package_io = import_module(
+    "github.com/kurtosis-tech/eth2-package/src/package_io/constants.star"
+)
+
+
+RPC_PORT_NUM = 8545
+WS_PORT_NUM = 8546
+DISCOVERY_PORT_NUM = 30303
+ENGINE_RPC_PORT_NUM = 8551
+METRICS_PORT_NUM = 9001
+
+# The min/max CPU/memory that the execution node can use
+EXECUTION_MIN_CPU = 100
+EXECUTION_MAX_CPU = 1000
+EXECUTION_MIN_MEMORY = 256
+EXECUTION_MAX_MEMORY = 1024
+
+# Port IDs
+RPC_PORT_ID = "rpc"
+WS_PORT_ID = "ws"
+TCP_DISCOVERY_PORT_ID = "tcp-discovery"
+UDP_DISCOVERY_PORT_ID = "udp-discovery"
+ENGINE_RPC_PORT_ID = "engine-rpc"
+METRICS_PORT_ID = "metrics"
+
+# Paths
+METRICS_PATH = "/metrics"
+GENESIS_DATA_MOUNT_DIRPATH = "/genesis"
+PREFUNDED_KEYS_MOUNT_DIRPATH = "/prefunded-keys"
+
+# The dirpath of the execution data directory on the client container
+EXECUTION_DATA_DIRPATH_ON_CLIENT_CONTAINER = "/execution-data"
+
+PRIVATE_IP_ADDRESS_PLACEHOLDER = "KURTOSIS_IP_ADDR_PLACEHOLDER"
+
+USED_PORTS = {
+    RPC_PORT_ID: shared_utils.new_port_spec(RPC_PORT_NUM, shared_utils.TCP_PROTOCOL),
+    WS_PORT_ID: shared_utils.new_port_spec(WS_PORT_NUM, shared_utils.TCP_PROTOCOL),
+    TCP_DISCOVERY_PORT_ID: shared_utils.new_port_spec(
+        DISCOVERY_PORT_NUM, shared_utils.TCP_PROTOCOL
+    ),
+    UDP_DISCOVERY_PORT_ID: shared_utils.new_port_spec(
+        DISCOVERY_PORT_NUM, shared_utils.UDP_PROTOCOL
+    ),
+    ENGINE_RPC_PORT_ID: shared_utils.new_port_spec(
+        ENGINE_RPC_PORT_NUM, shared_utils.TCP_PROTOCOL
+    ),
+    METRICS_PORT_ID: shared_utils.new_port_spec(
+        METRICS_PORT_NUM, shared_utils.TCP_PROTOCOL
+    ),
+}
+
+ENTRYPOINT_ARGS = ["sh", "-c"]
+
+VERBOSITY_LEVELS = {
+    package_io.GLOBAL_CLIENT_LOG_LEVEL.error: "v",
+    package_io.GLOBAL_CLIENT_LOG_LEVEL.warn: "vv",
+    package_io.GLOBAL_CLIENT_LOG_LEVEL.info: "vvv",
+    package_io.GLOBAL_CLIENT_LOG_LEVEL.debug: "vvvv",
+    package_io.GLOBAL_CLIENT_LOG_LEVEL.trace: "vvvvv",
+}
+
+
+def launch(
+    plan,
+    launcher,
+    service_name,
+    image,
+    participant_log_level,
+    global_log_level,
+    # If empty then the node will be launched as a bootnode
+    existing_el_clients,
+    el_min_cpu,
+    el_max_cpu,
+    el_min_mem,
+    el_max_mem,
+    extra_params,
+    extra_env_vars,
+):
+    log_level = input_parser.get_client_log_level_or_default(
+        participant_log_level, global_log_level, VERBOSITY_LEVELS
+    )
+
+    el_min_cpu = el_min_cpu if int(el_min_cpu) > 0 else EXECUTION_MIN_CPU
+    el_max_cpu = el_max_cpu if int(el_max_cpu) > 0 else EXECUTION_MAX_CPU
+    el_min_mem = el_min_mem if int(el_min_mem) > 0 else EXECUTION_MIN_MEMORY
+    el_max_mem = el_max_mem if int(el_max_mem) > 0 else EXECUTION_MAX_MEMORY
+
+    config, jwt_secret_json_filepath_on_client = get_config(
+        launcher.el_genesis_data,
+        image,
+        existing_el_clients,
+        log_level,
+        el_min_cpu,
+        el_max_cpu,
+        el_min_mem,
+        el_max_mem,
+        extra_params,
+        extra_env_vars,
+    )
+
+    service = plan.add_service(service_name, config)
+
+    enode = el_admin_node_info.get_enode_for_node(plan, service_name, RPC_PORT_ID)
+
+    jwt_secret = shared_utils.read_file_from_service(
+        plan, service_name, jwt_secret_json_filepath_on_client
+    )
+
+    metric_url = "{0}:{1}".format(service.ip_address, METRICS_PORT_NUM)
+    reth_metrics_info = node_metrics.new_node_metrics_info(
+        service_name, METRICS_PATH, metric_url
+    )
+
+    return el_client_context.new_el_client_context(
+        "reth",
+        "",  # reth has no enr
+        enode,
+        service.ip_address,
+        RPC_PORT_NUM,
+        WS_PORT_NUM,
+        ENGINE_RPC_PORT_NUM,
+        jwt_secret,
+        service_name,
+        [reth_metrics_info],
+    )
+
+
+def get_config(
+    genesis_data,
+    image,
+    existing_el_clients,
+    verbosity_level,
+    el_min_cpu,
+    el_max_cpu,
+    el_min_mem,
+    el_max_mem,
+    extra_params,
+    extra_env_vars,
+):
+    genesis_json_filepath_on_client = shared_utils.path_join(
+        GENESIS_DATA_MOUNT_DIRPATH, genesis_data.geth_genesis_json_relative_filepath
+    )
+    jwt_secret_json_filepath_on_client = shared_utils.path_join(
+        GENESIS_DATA_MOUNT_DIRPATH, genesis_data.jwt_secret_relative_filepath
+    )
+
+    init_datadir_cmd_str = "reth init --datadir={0} --chain={1}".format(
+        EXECUTION_DATA_DIRPATH_ON_CLIENT_CONTAINER,
+        genesis_json_filepath_on_client,
+    )
+
+    cmd = [
+        "reth",
+        "node",
+        "-{0}".format(verbosity_level),
+        "--datadir=" + EXECUTION_DATA_DIRPATH_ON_CLIENT_CONTAINER,
+        "--chain=" + genesis_json_filepath_on_client,
+        "--http",
+        "--http.port={0}".format(RPC_PORT_NUM),
+        "--http.addr=0.0.0.0",
+        "--http.corsdomain=*",
+        # WARNING: The admin info endpoint is enabled so that we can easily get ENR/enode, which means
+        #  that users should NOT store private information in these Kurtosis nodes!
+        "--http.api=admin,net,eth",
+        "--ws",
+        "--ws.addr=0.0.0.0",
+        "--ws.port={0}".format(WS_PORT_NUM),
+        "--ws.api=net,eth",
+        "--ws.origins=*",
+        "--nat=extip:" + PRIVATE_IP_ADDRESS_PLACEHOLDER,
+        "--authrpc.port={0}".format(ENGINE_RPC_PORT_NUM),
+        "--authrpc.jwtsecret={0}".format(jwt_secret_json_filepath_on_client),
+        "--authrpc.addr=0.0.0.0",
+        "--metrics=0.0.0.0:{0}".format(METRICS_PORT_NUM),
+    ]
+
+    if len(existing_el_clients) > 0:
+        cmd.append(
+            "--bootnodes="
+            + ",".join(
+                [
+                    ctx.enode
+                    for ctx in existing_el_clients[: package_io.MAX_ENODE_ENTRIES]
+                ]
+            )
+        )
+
+    if len(extra_params) > 0:
+        # this is a repeated<proto type>, we convert it into Starlark
+        cmd.extend([param for param in extra_params])
+
+    cmd_str = " ".join(cmd)
+
+    subcommand_strs = [
+        init_datadir_cmd_str,
+        cmd_str,
+    ]
+    command_str = " && ".join(subcommand_strs)
+
+    return (
+        ServiceConfig(
+            image=image,
+            ports=USED_PORTS,
+            cmd=[command_str],
+            files={
+                GENESIS_DATA_MOUNT_DIRPATH: genesis_data.files_artifact_uuid,
+            },
+            entrypoint=ENTRYPOINT_ARGS,
+            private_ip_address_placeholder=PRIVATE_IP_ADDRESS_PLACEHOLDER,
+            min_cpu=el_min_cpu,
+            max_cpu=el_max_cpu,
+            min_memory=el_min_mem,
+            max_memory=el_max_mem,
+            env_vars=extra_env_vars,
+        ),
+        jwt_secret_json_filepath_on_client,
+    )
+
+
+def new_reth_launcher(el_genesis_data):
+    return struct(
+        el_genesis_data=el_genesis_data,
+    )

src/mev_boost/mev_boost_launcher.star

@@ -45,7 +45,7 @@ def get_config(mev_boost_launcher, network_id, mev_boost_image):
         cmd=command,
         env_vars={
             # TODO(maybe) remove the hardcoding
-            # This is set to match this file https://github.com/kurtosis-tech/eth-network-package/blob/main/static_files/genesis-generation-config/cl/config.yaml.tmpl#L11
+            # This is set to match this file https://github.com/kurtosis-tech/eth2-package/blob/main/static_files/genesis-generation-config/cl/config.yaml.tmpl#L11
             # latest-notes
             # does this need genesis time to be set as well
             "GENESIS_FORK_VERSION": "0x10000038",

src/node_metrics_info.star

+# this is a dictionary as this will get serialzed to JSON
+def new_node_metrics_info(name, path, url):
+    return {"name": name, "path": path, "url": url}

src/package_io/constants.star

 EL_CLIENT_TYPE = struct(
-    geth="geth", erigon="erigon", nethermind="nethermind", besu="besu"
+    geth="geth",
+    erigon="erigon",
+    nethermind="nethermind",
+    besu="besu",
+    reth="reth",
+    ethereumjs="ethereumjs",
 )
 
 CL_CLIENT_TYPE = struct(
@@ -17,3 +22,13 @@ GLOBAL_CLIENT_LOG_LEVEL = struct(
     debug="debug",
     trace="trace",
 )
+
+VALIDATING_REWARDS_ACCOUNT = "0x878705ba3f8Bc32FCf7F4CAa1A35E72AF65CF766"
+MAX_ENR_ENTRIES = 20
+MAX_ENODE_ENTRIES = 20
+
+GENESIS_VALIDATORS_ROOT_PLACEHOLDER = "GENESIS_VALIDATORS_ROOT_PLACEHOLDER"
+
+DEFAULT_SNOOPER_IMAGE = "parithoshj/json_rpc_snoop:v1.0.0-x86"
+
+ARCHIVE_MODE = True

src/participant.star

+def new_participant(
+    el_client_type,
+    cl_client_type,
+    el_client_context,
+    cl_client_context,
+    snooper_engine_context,
+):
+    return struct(
+        el_client_type=el_client_type,
+        cl_client_type=cl_client_type,
+        el_client_context=el_client_context,
+        cl_client_context=cl_client_context,
+        snooper_engine_context=snooper_engine_context,
+    )

src/prelaunch_data_generator/cl_genesis/cl_genesis_data.star

+def new_cl_genesis_data(
+    files_artifact_uuid,
+    jwt_secret_rel_filepath,
+    config_yml_rel_filepath,
+    genesis_ssz_rel_filepath,
+    genesis_validators_root="",
+):
+    return struct(
+        files_artifact_uuid=files_artifact_uuid,
+        jwt_secret_rel_filepath=jwt_secret_rel_filepath,
+        config_yml_rel_filepath=config_yml_rel_filepath,
+        genesis_ssz_rel_filepath=genesis_ssz_rel_filepath,
+        genesis_validators_root=genesis_validators_root,
+    )

src/prelaunch_data_generator/cl_validator_keystores/generate_keystores_result.star

+# Package object containing information about the keystores that were generated for validators
+# during genesis creation
+def new_generate_keystores_result(
+    prysm_password_artifact_uuid, prysm_password_relative_filepath, per_node_keystores
+):
+    return struct(
+        # Files artifact UUID where the Prysm password is stored
+        prysm_password_artifact_uuid=prysm_password_artifact_uuid,
+        # Relative to root of files artifact
+        prysm_password_relative_filepath=prysm_password_relative_filepath,
+        # Contains keystores-per-client-type for each node in the network
+        per_node_keystores=per_node_keystores,
+    )

src/prelaunch_data_generator/cl_validator_keystores/keystore_files.star

+# One of these will be created per node we're trying to start
+def new_keystore_files(
+    files_artifact_uuid,
+    raw_keys_relative_dirpath,
+    raw_secrets_relative_dirpath,
+    nimbus_keys_relative_dirpath,
+    prysm_relative_dirpath,
+    teku_keys_relative_dirpath,
+    teku_secrets_relative_dirpath,
+):
+    return struct(
+        files_artifact_uuid=files_artifact_uuid,
+        # ------------ All directories below are relative to the root of the files artifact ----------------
+        raw_keys_relative_dirpath=raw_keys_relative_dirpath,
+        raw_secrets_relative_dirpath=raw_secrets_relative_dirpath,
+        nimbus_keys_relative_dirpath=nimbus_keys_relative_dirpath,
+        prysm_relative_dirpath=prysm_relative_dirpath,
+        teku_keys_relative_dirpath=teku_keys_relative_dirpath,
+        teku_secrets_relative_dirpath=teku_secrets_relative_dirpath,
+    )

src/prelaunch_data_generator/el_genesis/el_genesis_data.star

+def new_el_genesis_data(
+    files_artifact_uuid,
+    jwt_secret_relative_filepath,
+    geth_genesis_json_relative_filepath,
+    erigon_genesis_json_relative_filepath,
+    nethermind_genesis_json_relative_filepath,
+    besu_genesis_json_relative_filepath,
+):
+    return struct(
+        files_artifact_uuid=files_artifact_uuid,
+        jwt_secret_relative_filepath=jwt_secret_relative_filepath,
+        geth_genesis_json_relative_filepath=geth_genesis_json_relative_filepath,
+        erigon_genesis_json_relative_filepath=erigon_genesis_json_relative_filepath,
+        nethermind_genesis_json_relative_filepath=nethermind_genesis_json_relative_filepath,
+        besu_genesis_json_relative_filepath=besu_genesis_json_relative_filepath,
+    )

src/snooper/snooper_engine_context.star

+def new_snooper_engine_client_context(ip_addr, engine_rpc_port_num):
+    return struct(
+        ip_addr=ip_addr,
+        engine_rpc_port_num=engine_rpc_port_num,
+    )

static_files/genesis-generation-config/cl/mnemonics.yaml.tmpl

+- mnemonic: "{{ .PreregisteredValidatorKeysMnemonic }}"  # a 24 word BIP 39 mnemonic
+  # Number of validator keys to preregister inside the outputted CL genesis.ssz
+  count: {{ .NumValidatorKeysToPreregister }}