Add new labels: integration_maturity, canonical_name and chain_selector (#65)

Author: zytek

.gitignore

@@ -15,3 +15,4 @@ local*
 # Python
 venv
 __pycache__
+.coverage

config/exporter_example/config.yml

@@ -2,6 +2,9 @@ blockchain: "Example Chain" # Name of blockchain i.e "Ethereum"
 chain_id: 1              # Chain ID, can be found at https://chainlist.org/
 network_name: "Example"  # Name of the blokckchain network i.e Rinkeby
 network_type: "Example"  # Type of the blockchain network, only two values allowed (Mainnet|Testnet)
+integration_maturity: "development" # Integration Maturity - (production|development)
+canonical_name: "example-chain-testnet" # Canonical name as set by BIX
+chain_selector: 121212 # CCIP chain selector, use -1 if absent
 connection_parameters:
   open_timeout: 6 # Timeout when opening websocket connection
   close_timeout: 1 # Timeout when closing websocket connection
@@ -11,7 +14,7 @@ connection_parameters:
 collector: "evm" # This will load different collectors based on what mode exporter will run with Supported modes are: "evm", "solana", "conflux", "cardano", "bitcoin"
 endpoints: # List of endpoints with their metadata.
   - url: wss://example-rpc-1.com/ws # RPC Endpoint websocket endpoint (Must start with wss:// or https://)
-    provider: Provider1 # Provider (Must be present in allowed providers list. Please check src/settings.py line 24) The purpose is to make sure we do not have same providers spelled differently                       
+    provider: Provider1 # Provider (Must be present in allowed providers list. Please check src/settings.py line 24) The purpose is to make sure we do not have same providers spelled differently
   - url: wss://example-rpc-2.com/ws
     provider: Provider2
   - url: wss://example-rpc-3.com/ws
@@ -25,4 +28,4 @@ endpoints: # List of endpoints with their metadata.
 
 
 
-## 
+##

requirements-dev.txt

@@ -1,5 +1,5 @@
 pytest==7.2.1
-pylint==2.16.2
+pylint==3.3.1
 coverage==7.1.0
 requests==2.28.2
 requests_mock==1.10.0

src/configuration.py

@@ -59,6 +59,12 @@ def _load_configuration(self):
             And(str),
             'network_type':
             And(str, lambda s: s in ('Testnet', 'Mainnet')),
+            'integration_maturity':
+            And(str, lambda s: s in ('production', 'development')),
+            'canonical_name':
+            And(str),
+            'chain_selector':
+            And(int),
             'collector':
             And(str, lambda s: s in supported_collectors),
             Optional('connection_parameters'): {

src/exporter.py

@@ -20,7 +20,7 @@ def exporter(environ, start_fn):  # pylint: disable=inconsistent-return-statemen
     """Web-server endpoints routing."""
     match environ['PATH_INFO']:
         case '/metrics':
-            return metrics_app(environ, start_fn)
+            return metrics_app(environ, start_fn) # pylint: disable=possibly-used-before-assignment
         case _:
             return return404(environ, start_fn)
 

src/metrics.py

@@ -12,6 +12,7 @@ class MetricsLoader():
     def __init__(self):
         self._labels = [
             'url', 'provider', 'blockchain', 'network_name', 'network_type',
+            'integration_maturity', 'canonical_name', 'chain_selector',
             'evmChainID'
         ]
 

src/registries.py

@@ -9,13 +9,15 @@
 class Endpoint():  # pylint: disable=too-few-public-methods
     """RPC Endpoint class, to store metadata."""
 
-    def __init__(  # pylint: disable=too-many-arguments
-            self, url, provider, blockchain, network_name, network_type,
+    def __init__(  # pylint: disable=too-many-arguments,too-many-positional-arguments
+            self, url, provider, blockchain, network_name, network_type, integration_maturity,
+            canonical_name, chain_selector,
             chain_id, **client_parameters):
         self.url = url
         self.chain_id = chain_id
         self.labels = [
-            url, provider, blockchain, network_name, network_type,
+            url, provider, blockchain, network_name, network_type, integration_maturity,
+            canonical_name, str(chain_selector),
             str(chain_id)
         ]
         self.client_parameters = client_parameters
@@ -50,6 +52,9 @@ def get_endpoint_registry(self) -> list:
                          self.blockchain,
                          self.get_property('network_name'),
                          self.get_property('network_type'),
+                         self.get_property('integration_maturity'),
+                         self.get_property('canonical_name'),
+                         self.get_property('chain_selector'),
                          self.get_property('chain_id'),
                          **self.client_parameters))
         return endpoints_list

src/test_configuration.py

@@ -50,6 +50,12 @@ def test_configuration_attribute(self):
             "TestNetwork",
             "network_type":
             "Mainnet",
+            "integration_maturity":
+            "development",
+            "canonical_name":
+            "test-network-mainnet",
+            "chain_selector":
+            121212,
             "collector":
             "evm",
             "endpoints": [{

src/test_metrics.py

@@ -13,7 +13,9 @@ class TestMetricsLoader(TestCase):
     def setUp(self):
         self.metrics_loader = MetricsLoader()
         self.labels = [
-            'url', 'provider', 'blockchain', 'network_name', 'network_type', 'evmChainID'
+            'url', 'provider', 'blockchain', 'network_name', 'network_type', 
+            'integration_maturity', 'canonical_name', 'chain_selector',
+            'evmChainID'
         ]
 
     def test_labels(self):

src/test_registries.py

@@ -17,10 +17,15 @@ def setUp(self):
         self.blockchain = "test_chain"
         self.network_name = "test_network"
         self.network_type = "ETH"
+        self.integration_maturity = "development"
+        self.canonical_name = "test-chain-network"
+        self.chain_selector = 121212
         self.chain_id = 123
         self.client_params = {"dummy": "data"}
         self.endpoint = Endpoint(self.url, self.provider, self.blockchain,
                                  self.network_name, self.network_type,
+                                 self.integration_maturity, self.canonical_name,
+                                 self.chain_selector,
                                  self.chain_id, **self.client_params)
 
     def test_url_attribute(self):
@@ -34,7 +39,10 @@ def test_chain_id_attribute(self):
     def test_labels_attribute(self):
         """Tests the labels attribute is set correctly"""
         labels = [self.url, self.provider, self.blockchain,
-                  self.network_name, self.network_type, str(self.chain_id)]
+                  self.network_name, self.network_type,
+                  self.integration_maturity, self.canonical_name,
+                  str(self.chain_selector),
+                  str(self.chain_id)]
         self.assertEqual(labels, self.endpoint.labels)