feat(hip-3-pusher): Support SEDA pass-through field types (#3460)

Author: merolish

apps/hip-3-pusher/pyproject.toml

@@ -1,6 +1,6 @@
 [project]
 name = "hip-3-pusher"
-version = "0.2.10"
+version = "0.2.11"
 description = "Hyperliquid HIP-3 market oracle pusher"
 readme = "README.md"
 requires-python = "==3.13.*"

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

@@ -64,6 +64,9 @@ async def main() -> None:
         price_state.seda_state,
         price_state.seda_last_state,
         price_state.seda_ema_state,
+        price_state.seda_oracle_state,
+        price_state.seda_mark_state,
+        price_state.seda_external_state,
     )
     user_limit_listener = UserLimitListener(
         config, metrics, publisher.user_limit_address

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

@@ -122,6 +122,9 @@ class PriceState:
     SEDA = "seda"
     SEDA_LAST = "seda_last"
     SEDA_EMA = "seda_ema"
+    SEDA_ORACLE = "seda_oracle"
+    SEDA_MARK = "seda_mark"
+    SEDA_EXTERNAL = "seda_external"
 
     def __init__(self, config: Config) -> None:
         self.market_name = config.hyperliquid.market_name
@@ -138,6 +141,9 @@ def __init__(self, config: Config) -> None:
         self.seda_state = PriceSourceState(self.SEDA)
         self.seda_last_state = PriceSourceState(self.SEDA_LAST)
         self.seda_ema_state = PriceSourceState(self.SEDA_EMA)
+        self.seda_oracle_state = PriceSourceState(self.SEDA_ORACLE)
+        self.seda_mark_state = PriceSourceState(self.SEDA_MARK)
+        self.seda_external_state = PriceSourceState(self.SEDA_EXTERNAL)
 
         # Map source names to state objects for dynamic lookup
         self.all_states: dict[str, PriceSourceState] = {
@@ -149,6 +155,9 @@ def __init__(self, config: Config) -> None:
             self.SEDA: self.seda_state,
             self.SEDA_LAST: self.seda_last_state,
             self.SEDA_EMA: self.seda_ema_state,
+            self.SEDA_ORACLE: self.seda_oracle_state,
+            self.SEDA_MARK: self.seda_mark_state,
+            self.SEDA_EXTERNAL: self.seda_external_state,
         }
 
     def get_all_prices(self) -> OracleUpdate:

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

@@ -59,13 +59,19 @@ class SedaListener:
     """
 
     SOURCE_NAME = "seda"
+    ORACLE_PX_FIELD = "oracle_px"
+    MARK_PXS_FIELD = "mark_pxs"
+    EXT_PERP_PX_FIELD = "ext_perp_px"
 
     def __init__(
         self,
         config: Config,
         seda_state: PriceSourceState,
         seda_last_state: PriceSourceState,
         seda_ema_state: PriceSourceState,
+        seda_oracle_state: PriceSourceState,
+        seda_mark_state: PriceSourceState,
+        seda_external_state: PriceSourceState,
         api_key_override: str | None = None,
     ) -> None:
         self.url = config.seda.url
@@ -81,6 +87,9 @@ def __init__(
         self.seda_state = seda_state
         self.seda_last_state = seda_last_state
         self.seda_ema_state = seda_ema_state
+        self.seda_oracle_state = seda_oracle_state
+        self.seda_mark_state = seda_mark_state
+        self.seda_external_state = seda_external_state
 
         self.price_field = config.seda.price_field
         self.timestamp_field = config.seda.timestamp_field
@@ -224,6 +233,19 @@ def _parse_seda_message(self, feed_name: str, message: dict[str, Any]) -> None:
                 feed_name, PriceUpdate(ema_price, timestamp, session_flag)
             )
 
+        # new format with exact pass-through data
+        oracle_px = result.get(self.ORACLE_PX_FIELD)
+        logger.debug("SEDA feed: {} oracle_px: {}", feed_name, oracle_px)
+        self.seda_oracle_state.put(feed_name, PriceUpdate(oracle_px, timestamp))
+
+        mark_pxs = result.get(self.MARK_PXS_FIELD)
+        logger.debug("SEDA feed: {} mark_pxs: {}", feed_name, mark_pxs)
+        self.seda_mark_state.put(feed_name, PriceUpdate(mark_pxs, timestamp))
+
+        ext_perp_px = result.get(self.EXT_PERP_PX_FIELD)
+        logger.debug("SEDA feed: {} ext_perp_px: {}", feed_name, ext_perp_px)
+        self.seda_external_state.put(feed_name, PriceUpdate(ext_perp_px, timestamp))
+
     def get_parsed_result(self, feed_name: str) -> dict[str, Any] | None:
         """
         Get parsed result for a feed from state.