remove pair source rounding as Hyperliquid handles it

Author: merolish

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

@@ -85,11 +85,14 @@ def get_prices(self, symbol_configs: dict[str, list[PriceSourceConfig]], oracle_
         pxs = {}
         for symbol in symbol_configs:
             for source_config in symbol_configs[symbol]:
-                # find first valid price in the waterfall
-                px = self.get_price(source_config, oracle_update)
-                if px is not None:
-                    pxs[f"{self.market_name}:{symbol}"] = str(px)
-                    break
+                try:
+                    # find first valid price in the waterfall
+                    px = self.get_price(source_config, oracle_update)
+                    if px is not None:
+                        pxs[f"{self.market_name}:{symbol}"] = str(px)
+                        break
+                except Exception as e:
+                    logger.exception("get_price exception for symbol: {} source_config: {} error: {}", symbol, source_config, e)
         return pxs
 
     def get_price(self, price_source_config: PriceSourceConfig, oracle_update: OracleUpdate):
@@ -125,10 +128,10 @@ def get_price_from_pair_source(self, base_source: PriceSource, quote_source: Pri
         if base_price is None:
             return None
         quote_price = self.get_price_from_single_source(quote_source)
-        if quote_price is None:
+        if quote_price is None or float(quote_price) == 0:
             return None
 
-        return str(round(float(base_price) / float(quote_price), 2))
+        return str(float(base_price) / float(quote_price))
 
     def get_price_from_oracle_mid_average(self, symbol: str, oracle_update: OracleUpdate):
         oracle_price = oracle_update.oracle.get(symbol)

apps/hip-3-pusher/tests/test_price_state.py

@@ -61,7 +61,7 @@ def test_fallback_lazer():
     price_state.lazer_state.put(8, PriceUpdate("99000000", now - price_state.stale_price_threshold_seconds / 2.0))
 
     oracle_update = price_state.get_all_prices()
-    assert oracle_update.oracle == {f"{DEX}:{SYMBOL}": "111616.16"}
+    assert oracle_update.oracle == {f"{DEX}:{SYMBOL}": "111616.16161616161"}
 
 
 
@@ -81,7 +81,7 @@ def test_fallback_hermes():
                                  PriceUpdate("98000000", now - price_state.stale_price_threshold_seconds / 2.0))
 
     oracle_update = price_state.get_all_prices()
-    assert oracle_update.oracle == {f"{DEX}:{SYMBOL}": "113265.31"}
+    assert oracle_update.oracle == {f"{DEX}:{SYMBOL}": "113265.30612244898"}
 
 
 def test_all_fail():