besu seems done

src/module_io/parse_input.star

@@ -115,6 +115,14 @@ def parse_input(input_args):
 	return result
 
 
+def get_client_log_level_or_default(participant_log_level, global_log_level, client_log_levels):
+	log_level = participant_log_level
+	if log_level == "":
+		log_level = client_log_levels.get(global_log_level, "")
+		if log_level == "":
+			fail("No participant log level defined, and the client log level has no mapping for global log level '{0}'".format(global_log_level))
+	return log_level
+
 
 def get_value_or_name(value):
 	if type(value) == ENUM_TYPE:

src/participant_network/el/besu/besu_launcher.star

-load("github.com/kurtosis-tech/eth2-module/src/shared_utils/shared_utils.star", "new_port_spec")
+load("github.com/kurtosis-tech/eth2-module/src/shared_utils/shared_utils.star", "new_port_spec", "path_join")
+load("github.com/kurtosis-tech/eth2-module/src/module_io/parse_input.star", "get_client_log_level_or_default")
+load("github.com/kurtosis-tech/eth2-module/src/el/el_client_context.star", "new_el_client_context")
 
 module_io = import_types("github.com/kurtosis-tech/eth2-module/types.proto")
 
@@ -24,7 +26,7 @@ ENGINE_WS_RPC_PORT_ID = "engineWsRpc"
 GET_NODE_INFO_MAX_RETRIES = 20
 GET_NODE_INFO_TIME_BETWEEN_RETRIES = 1 * time.second
 
-PRIVATE_IP_ADDRESS_PLACEHOLDER = "KURTOSIS_PRIVATE_IP_ADDR_PLACEHOLDER"
+PRIVATE_IP_ADDRESS_PLACEHOLDER = "KURTOSIS_IP_ADDR_PLACEHOLDER"
 
 # TODO push this into shared_utils
 TCP_PROTOCOL = "TCP"
@@ -47,4 +49,95 @@ BESU_LOG_LEVELS = {
 	module_io.GlobalClientLogLeve.info:  "INFO",
 	module_io.GlobalClientLogLevel.debug: "DEBUG",
 	module_io.GlobalClientLogLevel.trace: "TRACE",
-}
\ No newline at end of file
+}
+
+
+
+def launch(
+	launcher,
+	service_id,
+	image,
+	participant_log_level,
+	global_log_level,
+	existing_el_clients,
+	extra_params):
+	
+	log_level = get_client_log_level_or_default(participant_log_level, global_log_level, BESU_LOG_LEVELS)
+
+	service_config  = get_service_config(launcher, image, network_id, existing_el_clients, log_level, extra_params)
+
+	service = add_service(service_id, service_config)
+
+	# TODO add facts & waits
+
+	return new_el_client_context(
+		"", # besu has no ENR
+		"", # TODO add Enode from wait & fact,
+		service.ip_address,
+		RPC_PORT_NUM,
+		WS_PORT_NUM,
+		ENGINE_HTTP_RPC_PORT_NUM
+	)
+
+
+def get_service_config(launcher, image, existing_el_clients, log_level, extra_params):
+	network_id = launcher.network_id
+	genesis_data = launcher.el_genesis_data
+
+	if len(existing_el_clients) < 0:
+		fail("Besu node cannot be boot nodes, and due to a bug it requires two nodes to exist beforehand")
+
+	boot_node_1 = existing_el_clients[0]
+	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)
+	jwt_secret_json_filepath_on_client = path_join(GENESIS_DATA_DIRPATH_ON_CLIENT_CONTAINER, genesis_data.jwt_secret_relative_filepath)
+
+	launch_node_command = [
+		"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",
+		"--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",
+		"--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),
+	]
+
+	if len(existing_el_clients) > 0:
+		launch_node_command.append("--bootnodes={0},{1}".format(boot_node_1.enode, boot_node_2.enode))
+
+	if len(extra_params) > 0:
+		launch_node_command.append(extra_params)
+
+	return struct(
+		container_image_name = image,
+		used_ports = USED_PORTS,
+		cmd_args = launch_node_command,
+		files_artifact_mount_dirpaths = {
+			genesis_data.files_artifact_uuid: GENESIS_DATA_DIRPATH_ON_CLIENT_CONTAINER
+		},
+		# TODO add private IP address place holder when add servicde supports it
+		# for now this will work as we use the service config default above
+	)
+
+
+def new_besu_el_client_launcher(el_genesis_data, network_id):
+	return struct(
+		el_genesis_data = el_genesis_data,
+		network_id = network_id,
+	)