price source config metric

Author: merolish

apps/hip-3-pusher/src/pusher/main.py

@@ -27,6 +27,7 @@ def load_config():
         config_toml = tomllib.load(config_file)
         config = Config(**config_toml)
         logger.debug("Config loaded: {}", config)
+        logger.info("Price config: {}", config.price)
     return config
 
 
@@ -44,6 +45,7 @@ async def main():
 
     price_state = PriceState(config)
     metrics = Metrics(config)
+    metrics.set_price_configs(config.hyperliquid.market_name, config.price)
 
     publisher = Publisher(config, price_state, metrics)
     hyperliquid_listener = HyperliquidListener(config, price_state.hl_oracle_state, price_state.hl_mark_state, price_state.hl_mid_state)

apps/hip-3-pusher/src/pusher/metrics.py

@@ -3,7 +3,8 @@
 from opentelemetry.metrics import get_meter_provider, set_meter_provider
 from opentelemetry.sdk.metrics import MeterProvider
 
-from pusher.config import Config
+from pusher.config import Config, PriceConfig, PriceSourceConfig, ConstantSourceConfig, SingleSourceConfig, \
+    PairSourceConfig, OracleMidAverageConfig, PriceSource
 
 METER_NAME = "hip3pusher"
 
@@ -42,3 +43,41 @@ def _init_metrics(self):
             description="Interval between push requests (seconds)",
             unit="s",
         )
+        # labels: dex, price_type, symbol
+        self.price_config_counter = self.meter.create_counter(
+            name="hip_3_relayer_price_config",
+            description="Price source config",
+        )
+
+    def set_price_configs(self, dex: str, price_config: PriceConfig):
+        self._set_price_config_type(dex, price_config.oracle, "oracle")
+        self._set_price_config_type(dex, price_config.mark, "mark")
+        self._set_price_config_type(dex, price_config.external, "external")
+
+    def _set_price_config_type(self, dex: str, price_source_config: dict[str, list[PriceSourceConfig]], price_type: str):
+        for symbol in price_source_config:
+            source_config_str = ' | '.join(self._get_source_config_str(source_config) for source_config in price_source_config[symbol])
+            labels = {
+                "dex": dex,
+                "symbol": symbol,
+                "price_type": price_type,
+                "config": source_config_str,
+            }
+            self.price_config_counter.add(1, labels)
+
+    def _get_source_config_str(self, source_config: PriceSourceConfig):
+        if isinstance(source_config, ConstantSourceConfig):
+            return f"constant({source_config.value})"
+        elif isinstance(source_config, SingleSourceConfig):
+            return self._get_price_source_str(source_config.source)
+        elif isinstance(source_config, PairSourceConfig):
+            base_str = self._get_price_source_str(source_config.base_source)
+            quote_str = self._get_price_source_str(source_config.quote_source)
+            return f"pair({base_str},{quote_str})"
+        elif isinstance(source_config, OracleMidAverageConfig):
+            return f"oracle_mid_average({source_config.symbol})"
+        else:
+            return "unknown"
+
+    def _get_price_source_str(self, price_source: PriceSource):
+        return f"{price_source.source_name}({str(price_source.source_id)[:8]})"

apps/hip-3-pusher/src/pusher/seda_listener.py

@@ -17,7 +17,7 @@ class SedaListener:
     """
     def __init__(self, config: Config, seda_state: PriceSourceState):
         self.url = config.seda.url
-        self.api_key = Path(config.seda.api_key_path).read_text().strip()
+        self.api_key = Path(config.seda.api_key_path).read_text().strip() if config.seda.api_key_path else None
         self.feeds = config.seda.feeds
         self.poll_interval = config.seda.poll_interval
         self.poll_failure_interval = config.seda.poll_failure_interval