Refactor liquidation API and enhance routing

- Renamed the existing `api/liquidation.py` API to `api/liquidation_curves_api.py` for improved clarity.
- Updated the routing in `app.py` to include the new `liquidation_curves_api` under the `/api/liquidation-curves` path.
- Adjusted imports in `__init__.py` and other relevant files to reflect the new API structure.
- Renamed page/liquidation_curves.py to liquidation `liquidation_curves_page.py` to follow updated naming convention.
- Added a loading animation and error handling in the Streamlit interface for better user experience during data fetching.

Author: goldhaxx

backend/api/__init__.py

@@ -4,7 +4,7 @@
     deposits_api,
     health,
     high_leverage_api,
-    liquidation,
+    liquidation_curves_api,
     market_recommender_api,
     metadata,
     open_interest_api,

backend/api/liquidation.py renamed to backend/api/liquidation_curves_api.py

@@ -7,15 +7,23 @@
 router = APIRouter()
 
 
-@router.get("/liquidation-curve")
+@router.get("/liquidation-curves")
 def get_liquidation_curve(request: BackendRequest, market_index: int):
     vat: Vat = request.state.backend_state.vat
+    last_oracle_slot = getattr(request.state.backend_state, "last_oracle_slot", 0)
+    # Debug logging to understand the slot issue
+    print(f"[DEBUG] Liquidation API - last_oracle_slot: {last_oracle_slot}, pickle_path: {request.state.backend_state.current_pickle_path}")
     liquidations_long: list[tuple[float, float, str]] = []
     liquidations_short: list[tuple[float, float, str]] = []
     market_price = vat.perp_oracles.get(market_index)
     if market_price is None:
         print("Market price is None")
-        return {"liquidations_long": [], "liquidations_short": [], "market_price_ui": 0}
+        return {
+            "liquidations_long": [], 
+            "liquidations_short": [], 
+            "market_price_ui": 0,
+            "slot": last_oracle_slot
+        }
     market_price_ui = market_price.price / PRICE_PRECISION
     for pubkey, user in vat.users.user_map.items():
         perp_position = user.get_perp_position(market_index)
@@ -48,4 +56,5 @@ def get_liquidation_curve(request: BackendRequest, market_index: int):
         "liquidations_long": liquidations_long,
         "liquidations_short": liquidations_short,
         "market_price_ui": market_price_ui,
+        "slot": last_oracle_slot,
     }

backend/app.py

@@ -13,7 +13,7 @@
     backend_health,
     deposits_api,
     health,
-    liquidation,
+    liquidation_curves_api,
     market_recommender_api,
     metadata,
     open_interest_api,
@@ -80,7 +80,7 @@ async def lifespan(app: FastAPI):
 app.include_router(health.router, prefix="/api/health", tags=["health"])
 app.include_router(backend_health.router, prefix="/api/backend-health", tags=["backend-health"])
 app.include_router(metadata.router, prefix="/api/metadata", tags=["metadata"])
-app.include_router(liquidation.router, prefix="/api/liquidation", tags=["liquidation"])
+app.include_router(liquidation_curves_api.router, prefix="/api/liquidation-curves", tags=["liquidation-curves"])
 app.include_router(price_shock.router, prefix="/api/price-shock", tags=["price-shock"])
 app.include_router(
     asset_liability.router, prefix="/api/asset-liability", tags=["asset-liability"]

images/pacman.gif

@@ -12,7 +12,7 @@
 from page.backend import backend_page
 from page.deposits_page import deposits_page
 from page.health import health_page
-from page.liquidation_curves import liquidation_curves_page
+from page.liquidation_curves_page import liquidation_curves_page
 from page.market_inspector import market_inspector_page
 from page.orderbook import orderbook_page
 from page.pnl import pnl_page

src/main.py

@@ -1,19 +1,35 @@
 from collections import defaultdict
 from typing import List, Tuple, TypedDict
+import time
 
 import numpy as np
 import plotly.graph_objects as go
 import streamlit as st
 from driftpy.constants.perp_markets import mainnet_perp_market_configs
 
 from lib.api import fetch_api_data
+from src.utils import get_current_slot
+
+RETRY_DELAY_SECONDS = 5
 
 
 class PriceData(TypedDict):
     notional: float
     positions: List[Tuple[str, float]]
 
 
+def is_processing(result):
+    """Checks if the API result indicates backend processing."""
+    return isinstance(result, dict) and result.get("result") == "processing"
+
+
+def has_error(result):
+    """Checks if the API result indicates an error or is missing essential data."""
+    return result is None or (
+        isinstance(result, dict) and "liquidations_long" not in result
+    )
+
+
 def plot_liquidation_curves(liquidation_data):
     liquidations_long = liquidation_data["liquidations_long"]
     liquidations_short = liquidation_data["liquidations_short"]
@@ -133,23 +149,36 @@ def liquidation_curves_page():
     liquidation_data = None
     try:
         liquidation_data = fetch_api_data(
-            "liquidation",
-            "liquidation-curve",
+            "liquidation-curves",
+            "liquidation-curves",
             params=dict(st.query_params),
-            retry=True,
+            retry=False,
         )
     except Exception as e:
         st.write(e)
         st.stop()
 
-    if liquidation_data is None:
-        st.write("Fetching data for the first time...")
-        st.image(
-            "https://i.gifer.com/origin/8a/8a47f769c400b0b7d81a8f6f8e09a44a_w200.gif"
+    if is_processing(liquidation_data):
+        st.info(
+            f"Backend is processing liquidation data. Auto-refreshing in {RETRY_DELAY_SECONDS} seconds..."
         )
+        with st.spinner("Please wait..."):
+            time.sleep(RETRY_DELAY_SECONDS)
+        st.rerun()
+        return
+
+    if has_error(liquidation_data):
+        st.write("Fetching data for the first time...")
+        st.image("images/pacman.gif")
         st.write("Check again in one minute!")
         st.stop()
 
+    # Display slot age information
+    slot = liquidation_data.get("slot", 0)
+    current_slot = get_current_slot()
+    slot_age = current_slot - slot
+    st.info(f"Data from slot {slot}, which is {slot_age} slots old.")
+
     (
         long_fig,
         short_fig,

src/page/liquidation_curves.py renamed to src/page/liquidation_curves_page.py

@@ -27,7 +27,7 @@ def welcome_page():
     )
 
     st.page_link(
-        StreamlitPage("page/liquidation_curves.py", url_path="liquidation-curves"),
+        StreamlitPage("page/liquidation_curves_page.py", url_path="liquidation-curves"),
         label="💧 **Liquidations** - Explore liquidation curves and potential risks",
     )
     st.page_link(