added testnet verifier

README.md

@@ -11,7 +11,7 @@ This is the Startosis version of the popular [eth2-merge-kurtosis-module](https:
 - [x] prometheus (this is blocked on CL clients running)
 - [x] grafana (this is blocked on prometheus running)
 - [ ] grafana needs an upload files endpoint in Startosis
-- [ ] testnet_verifier (this is blocked on CL/EL clients running)
+- [x] testnet_verifier (this is blocked on CL/EL clients running)
 - [ ] transaction_spammer (this is blocked on EL clients running)
 - [ ] participant_network/participant_network
   - [ ] has most data generation things, needs to start EL/CL clients

src/testnet_verifier/testnet_verifier.star

+IMAGE_NAME = "marioevz/merge-testnet-verifier:latest"
+SERVICE_ID = "testnet-verifier"
+
+# We use Docker exec commands to run the commands we need, so we override the default
+SYNCHRONOUS_ENTRYPOINT_ARGS = {
+	"sleep",
+	"999999",
+}
+
+
+def launch_testnet_verifier(params, el_client_contexts, cl_client_contexts):
+	service_config = get_asynchronous_verification_service_config(params, el_client_contexts, cl_client_contexts)
+	add_service(SERVICE_ID, service_config)
+
+
+def run_synchronous_testnet_verification(params, el_client_contexts, cl_client_contexts):
+	service_config = get_synchronous_verification_service_config()
+	add_service(SERVICE_ID, service_config)
+
+	command = get_cmd()
+	exec(SERVICE_ID, command)
+
+
+def get_cmd(params, el_client_contexts, cl_client_contexts, add_binary_name):
+	command = []
+
+	if add_binary_name:
+		command.append("./merge_testnet_verifier")
+
+	command.append("--ttd 0")
+
+	for el_client_context in el_client_contexts:
+		command.append("--client")
+		command.append("{0},http://{1}:{2}".format(el_client_context.client_name, el_client_context.ip_addr, el_client_context.rpc_port_num))
+
+	for cl_client_context in cl_client_contexts:
+		command.append("--client")
+		command.append("{0},http://{1}:{2}".format(cl_client_context.client_name, cl_client_context.ip_addr, cl_client_context.http_port_num))
+
+	command.append("--ttd-epoch-limit 0")
+	command.append("--verif-epoch-limit")
+	# TODO make this an actual param
+	command.append("{0}".fomrat(param.verifications_epoch_limit))
+
+
+
+
+def get_asynchronous_verification_service_config(params, el_client_contexts, cl_client_contexts):
+	commands = get_cmd(params, el_client_contexts, cl_client_contexts)
+	return struct(
+		container_image_name = IMAGE_NAME,
+		cmd_args = commands,
+		# TODO remove this when used_ports is optional in add_service
+		used_ports = {},
+	)
+
+
+def get_synchronous_verification_service_config():
+	return struct(
+		container_image_name = IMAGE_NAME,
+		entry_point_args = ENTRYPOINT_ARGS,
+		# TODO remove this when used_ports is optional in add_service
+		used_ports = {},
+	)