Update app/app.py

app/app.py

@@ -12,17 +12,18 @@ import json
 import httpx
 from fastapi import FastAPI, Request
 from fastapi.responses import HTMLResponse, StreamingResponse
-from fastapi.templating import Jinja2Templates
+from fastapi.staticfiles import StaticFiles # <-- We use this instead of Jinja2
 
+# Relative imports for package structure
 from .price_fetcher import PriceFetcher
 from .arbitrage_analyzer import ArbitrageAnalyzer
 from .broker import signal_broker
 
-OPPORTUNITY_THRESHOLD = 0.0015  # 0.15% price difference to trigger a signal
+OPPORTUNITY_THRESHOLD = 0.0015  # 0.15% price difference
 
 @asynccontextmanager
 async def lifespan(app: FastAPI):
-    # This setup remains the same, but the logic it runs is now multi-asset.
+    """Manages application startup and shutdown events."""
     async with httpx.AsyncClient() as client:
         app.state.price_fetcher = PriceFetcher(client)
         app.state.arbitrage_analyzer = ArbitrageAnalyzer(client)
@@ -35,6 +36,7 @@ async def lifespan(app: FastAPI):
         except asyncio.CancelledError: print("Engine shut down.")
 
 async def run_arbitrage_detector(app: FastAPI):
+    """The core engine loop. Checks for opportunities and queues them."""
     while True:
         await app.state.price_fetcher.update_prices_async()
         all_prices = app.state.price_fetcher.get_all_prices()
@@ -59,10 +61,12 @@ async def run_arbitrage_detector(app: FastAPI):
 
         await asyncio.sleep(15)
 
+# --- FastAPI App Initialization ---
 app = FastAPI(title="Sentinel Arbitrage Engine", lifespan=lifespan)
-templates = Jinja2Templates(directory="templates")
 
+# --- HTML Rendering Helper ---
 def render_signal_card(payload: dict) -> str:
+    """Renders a dictionary of analysis into a styled HTML table row."""
     s = payload
     time_str = datetime.fromisoformat(s['timestamp']).strftime('%H:%M:%S UTC')
     pyth_class = "buy" if s['pyth_price'] < s['chainlink_price'] else "sell"
@@ -81,16 +85,19 @@ def render_signal_card(payload: dict) -> str:
     <div id="last-update-time" hx-swap-oob="true">{time_str}</div>
     """
 
-@app.get("/", response_class=HTMLResponse)
-async def serve_dashboard(request: Request):
-    return templates.TemplateResponse("index.html", {"request": request})
-
+# --- API Endpoints ---
 @app.get("/api/signals/stream")
 async def signal_stream(request: Request):
+    """SSE stream for the automated Signal Stream."""
     async def event_generator():
         while True:
             payload = await signal_broker.queue.get()
             html_card = render_signal_card(payload)
             data_payload = html_card.replace('\n', ' ').strip()
             yield f"event: message\ndata: {data_payload}\n\n"
-    return StreamingResponse(event_generator(), media_type="text/event-stream")
+    return StreamingResponse(event_generator(), media_type="text/event-stream")
+
+# --- Static File Server ---
+# This single mount point serves index.html for the root path "/"
+# and any other files like CSS or JS from the "static" directory.
+app.mount("/", StaticFiles(directory="static", html=True), name="static")