chore: deploy conduit node

HugoByte · Jan 29, 2024 · 85cb762 · 85cb762
1 parent 353f867
commit 85cb762
Show file tree

Hide file tree

Showing 3 changed files with 27 additions and 20 deletions.
diff --git a/config.json b/config.json
@@ -23,9 +23,10 @@
       "nodes": [
         {
           "name": "alice",
-          "node_type": "validator",
-          "prometheus": false
-
+          "node_type": "collator",
+          "prometheus": false,
+          "provider_url": "http://127.0.0.1:8000",
+          "request_id": 0
         },
         {
           "name": "bob",

diff --git a/package_io/utils.star b/package_io/utils.star
@@ -86,10 +86,10 @@ def check_config_validity(plan, chain_type, relaychain, parachains):
         for para in parachains:
             if len(para["nodes"]) != 0:
                 for node in para["nodes"]:
-                    if node["node_type"] in ["validator",  "full", "collator"]:
+                    if node["node_type"] in ["validator",  "full", "collator", "conduit"]:
                             plan.print("config for parachain is valid")
                     else:
-                        return fail("parachain node_type can be only validator/full/collator")
+                        return fail("parachain node_type can be only validator/full/collator/conduit")
 
 def upload_files(plan):
     plan.upload_files(src = "../parachain/static_files/configs", name = "configs")

diff --git a/parachain/parachain.star b/parachain/parachain.star
@@ -28,8 +28,8 @@ def start_local_parachain_node(plan, chain_type, parachain, para_id):
 
     for node in parachain["nodes"]:
         parachain_detail = {}
-        
-        if "ports" in node: 
+
+        if "ports" in node:
             rpc_port = node["ports"]["rpc_port"]
             lib2lib_port = node["ports"]["lib2lib_port"]
             prometheus_port = node["ports"]["prometheus_port"] if node["prometheus"] else None
@@ -38,12 +38,19 @@ def start_local_parachain_node(plan, chain_type, parachain, para_id):
             lib2lib_port = None
             prometheus_port = None
 
-        exec_comexec_commandmand = [
-            "/bin/bash",
-            "-c",
-            "{0} --base-path=/tmp/{1} --chain=/build/{1}-raw.json --rpc-port=9946 --port=30333 --rpc-external --rpc-cors=all --prometheus-external --{2} --collator --rpc-methods=unsafe --force-authoring --execution=wasm -- --chain=/app/raw-polkadot.json --execution=wasm".format(binary, chain_name, node["name"]),
-        ]
-
+        if node["node_type"] == "conduit":
+            exec_comexec_commandmand = [
+                "/bin/bash",
+                "-c",
+                "{0} --base-path=/tmp/{1} --chain=/build/{1}-raw.json --rpc-port=9946 --port=30333 --rpc-external --rpc-cors=all --prometheus-external --{2} --conduit --provider_url={3} --request_id={4} --rpc-methods=unsafe --force-authoring --execution=wasm -- --chain=/config/raw-polkadot.json --execution=wasm".format(binary, chain_name, node["name"], node["provider_url"], node["request_id"]),
+            ]
+        else:
+            exec_comexec_commandmand = [
+                "/bin/bash",
+                "-c",
+                "{0} --base-path=/tmp/{1} --chain=/build/{1}-raw.json --rpc-port=9946 --port=30333 --rpc-external --rpc-cors=all --prometheus-external --{2} --collator --rpc-methods=unsafe --force-authoring --execution=wasm -- --chain=/config/raw-polkadot.json --execution=wasm".format(binary, chain_name, node["name"]),
+            ]
+
         build_file = raw_service.name
         parachain_spawn_detail = node_setup.spawn_parachain(plan, node["prometheus"], image, "{0}-{1}-{2}".format(chain_name, node["name"], chain_type), exec_comexec_commandmand, build_file, rpc_port, prometheus_port, lib2lib_port)
         parachain_detail["service_name"] = parachain_spawn_detail.name
@@ -76,13 +83,13 @@ def start_nodes(plan, chain_type, parachains, relay_chain_ip):
         list: List of dictionaries containing service details of each parachain.
     """
     final_parachain_details = {}
-    
+
     for parachain in parachains:
-        para_id = register_para_slot.register_para_id(plan, relay_chain_ip)        
+        para_id = register_para_slot.register_para_id(plan, relay_chain_ip)
         parachain_details = start_local_parachain_node(plan, chain_type, parachain, para_id)
         register_para_slot.onboard_genesis_state_and_wasm(plan, para_id, parachain["name"], relay_chain_ip)
         final_parachain_details.update(parachain_details)
-    
+
     return final_parachain_details
 
 def run_testnet_mainnet(plan, chain_type, relaychain_name, parachain):
@@ -127,7 +134,7 @@ def run_testnet_mainnet(plan, chain_type, relaychain_name, parachain):
         "--rpc-external",
         "--rpc-methods=unsafe",
         "--unsafe-rpc-external",
-        ]
+    ]
 
     parachain_info = {parachain["name"]: {}}
     if parachain["name"] == "altair" or parachain["name"] == "centrifuge":
@@ -139,16 +146,15 @@ def run_testnet_mainnet(plan, chain_type, relaychain_name, parachain):
 
     final_parachain_info = {}
     for node in parachain["nodes"]:
-
-        if "ports" in node: 
+        if "ports" in node:
             rpc_port = node["ports"]["rpc_port"]
             lib2lib_port = node["ports"]["lib2lib_port"]
             prometheus_port = node["ports"]["prometheus_port"] if node["prometheus"] else None
         else:
             rpc_port = None
             lib2lib_port = None
             prometheus_port = None
-                
+
         command = common_command
         command = command + ["--name={0}".format(node["name"])]
         if node["node_type"] == "collator":