feat: Make it possible to specify RPC_URL via env var (#47)

Author: nahsi

app.py

@@ -47,7 +47,7 @@ def metrics_endpoint():
         config_file_path = os.getenv("CONFIG_FILE", "config.yml")
         config = config_loader.load_config(config_file_path)
 
-        rpc_url = config.rpc_url
+        rpc_url = os.getenv("RPC_URL") or config.rpc_url
         graph_node_url = config.graph_node_url
         port = int(os.getenv("PORT", str(config.port)))
 

deployment/job.nomad.hcl

@@ -74,6 +74,16 @@ job "fluence-network-exporter" {
         env         = true
       }
 
+      template {
+        data        = <<-EOH
+        {{- with secret "kv/fluence-network-exporter/${var.region}/chain" -}}
+        RPC_URL="{{ .Data.rpc_url }}"
+        {{- end -}}
+        EOH
+        destination = "secrets/secret.env"
+        env         = true
+      }
+
       resources {
         cpu        = 50
         memory     = 128

deployment/job.tf

@@ -25,6 +25,11 @@ resource "vault_policy" "fluence-network-exporter" {
     {
       capabilities = ["read"]
     }
+
+    path "kv/fluence-network-exporter/${local.region}/chain"
+    {
+      capabilities = ["read"]
+    }
   EOH
 }
 

network_metrics.py

@@ -4,23 +4,34 @@
 import threading
 from config_loader import AddressEntry
 import logging
+from urllib.parse import urlparse, urlunparse
 
 # Set up logging
 logger = logging.getLogger(__name__)
 
 
+def mask_secret(url: str) -> str:
+    parsed = urlparse(url)
+    if parsed.path and parsed.path != '/':
+        masked_path = '/****'
+        masked_url = urlunparse((parsed.scheme, parsed.netloc, masked_path, parsed.params, parsed.query, parsed.fragment))
+        return masked_url
+    return url
+
+
 def connect_rpc(url: str) -> Web3:
     """Connect to RPC."""
+    masked_url = mask_secret(url)
     try:
         web3 = Web3(Web3.HTTPProvider(url))
         if web3.is_connected():
-            logger.info(f"Successfully connected to the RPC endpoint: {url}")
+            logger.info(f"Successfully connected to the RPC endpoint: {masked_url}")
             return web3
         else:
             raise ConnectionError(
-                f"Failed to connect to the RPC endpoint: {url}")
+                f"Failed to connect to the RPC endpoint: {masked_url}")
     except Exception as e:
-        logger.error(f"Error connecting to RPC endpoint {url}: {e}")
+        logger.error(f"Error connecting to RPC endpoint {masked_url}: {e}")
         raise