implement grpc comms

.gitignore

@@ -1,3 +1,5 @@
 tmp/
+.idea/
 test
 params.yml
+*.DS_Store

src/cl/heimdall_v2/launcher.star

@@ -16,6 +16,7 @@ def launch(
     cl_node_ids,
     l1_rpc_url,
     el_rpc_url,
+    el_grpc_url,
     amqp_url,
     container_proc_manager_artifact,
 ):
@@ -38,7 +39,9 @@ def launch(
                     # URLs.
                     "amqp_url": amqp_url,
                     "el_rpc_url": el_rpc_url,
+                    "el_grpc_url": el_grpc_url,
                     "l1_rpc_url": l1_rpc_url,
+                    "cl_bor_grpc_flag": participant.get("cl_bor_grpc_flag"),
                     # Port numbers.
                     "rest_api_port_number": shared.REST_API_PORT_NUMBER,
                     "grpc_port_number": shared.GRPC_PORT_NUMBER,

src/cl/launcher.star

@@ -40,6 +40,7 @@ def launch(
 
     el_node_name = el_launcher.generate_name(participant, id)
     el_rpc_url = "http://{}:{}".format(el_node_name, el_shared.RPC_PORT_NUMBER)
+    el_grpc_url = "http://{}:{}".format(el_node_name, el_shared.GRPC_PORT_NUMBER)
 
     service = launch_method(
         plan,
@@ -51,6 +52,7 @@ def launch(
         node_ids,
         l1_rpc_url,
         el_rpc_url,
+        el_grpc_url,
         rabbitmq_url,
         container_proc_manager_artifact,
     )

src/config/input_parser.star

@@ -84,6 +84,7 @@ POLYGON_POS_PARTICIPANT = {
     "cl_indexer_pruning_enabled": constants.CL_INDEXER_PRUNING_ENABLED,
     "el_type": constants.EL_TYPE.bor,
     "el_image": constants.IMAGES.get("l2_el_bor_image"),
+    "cl_bor_grpc_flag": False,
     "count": 1,
 }
 

src/config/sanity_check.star

@@ -25,6 +25,7 @@ POLYGON_POS_PARAMS = {
         "el_bor_produce_witness",  # Allow bor to start producing witnesses.
         "el_bor_sync_with_witness",  # Enable bor to sync new blocks using witnesses.
         "el_bor_stateless_parallel_import",  # Enable bor to use parallel import in stateless mode.
+        "cl_bor_grpc_flag",  # Enable heimdall → bor gRPC transport (default HTTP).
         "count",
     ],
     "setup_images": [

src/el/bor/launcher.star

@@ -67,6 +67,7 @@ def launch(
                     "discovery_port_number": shared.DISCOVERY_PORT_NUMBER,
                     "metrics_port_number": shared.METRICS_PORT_NUMBER,
                     "pprof_port_number": shared.PPROF_PORT_NUMBER,
+                    "grpc_port_number": shared.GRPC_PORT_NUMBER,
                     "ethstats_server_port_number": constants.ETHSTATS_SERVER_PORT_NUMBER,
                 },
             ),
@@ -115,6 +116,10 @@ def launch(
                     number=shared.PPROF_PORT_NUMBER,
                     application_protocol="http",
                 ),
+                shared.GRPC_PORT_ID: PortSpec(
+                    number=shared.GRPC_PORT_NUMBER,
+                    application_protocol="grpc",
+                ),
             },
             files={
                 # app data

src/el/shared.star

@@ -14,6 +14,9 @@ METRICS_PORT_NUMBER = 7071
 PPROF_PORT_ID = "pprof"
 PPROF_PORT_NUMBER = 6060
 
+GRPC_PORT_ID = "grpc"
+GRPC_PORT_NUMBER = 3131
+
 # CPU and memory limits.
 MAX_CPU = 4000  # in milicores (4 cores)
 MAX_MEM = 16384  # in megabytes (16 GB)

static_files/cl/heimdall_v2/app.toml

@@ -247,10 +247,10 @@ eth_rpc_url = "{{.l1_rpc_url}}"
 bor_rpc_url = "{{.el_rpc_url}}"
 
 # GRPC flag for bor chain
-bor_grpc_flag = "false"
+bor_grpc_flag = "{{ if .cl_bor_grpc_flag }}true{{ else }}false{{ end }}"
 
 # GRPC endpoint for bor chain
-bor_grpc_url = "localhost:3131"
+bor_grpc_url = "{{.el_grpc_url}}"
 
 # RPC endpoint for cometBFT
 comet_bft_rpc_url = "http://0.0.0.0:{{.rpc_port_number}}"

static_files/el/bor/config.toml

@@ -129,6 +129,10 @@ ethstats = "{{.node_name}}:{{.ethstats_server_secret}}@ethstats-server:{{.ethsta
   # Enable expensive metrics collection and reporting (default: false)
   expensive = false
 
+[grpc]
+  # gRPC server for heimdall-bor communication.
+  addr = "0.0.0.0:{{.grpc_port_number}}"
+
 [pprof]
   # Enable the pprof HTTP server (default: false)
   pprof = true