44 lines
1.3 KiB
Python
44 lines
1.3 KiB
Python
"""Ranking endpoints – listings sorted by ELO."""
|
||
|
||
from fastapi import APIRouter, Depends
|
||
from sqlalchemy import text
|
||
from sqlalchemy.orm import Session
|
||
|
||
from app.config import settings
|
||
from app.database import get_db
|
||
from app.queries import LISTING_SELECT, row_to_listing
|
||
from app.schemas import RankingResponse
|
||
|
||
router = APIRouter()
|
||
|
||
|
||
@router.get("/rankings", response_model=list[RankingResponse])
|
||
def get_rankings(
|
||
status: str | None = None,
|
||
limit: int = 100,
|
||
offset: int = 0,
|
||
db: Session = Depends(get_db),
|
||
):
|
||
"""Return listings ranked by ELO rating (highest first).
|
||
|
||
Only listings in the stable sample (elo.sample_listings) are shown.
|
||
"""
|
||
query = LISTING_SELECT + f"""
|
||
INNER JOIN {settings.ELO_SCHEMA}.sample_listings s
|
||
ON l.global_id = s.global_id
|
||
"""
|
||
params: dict = {"limit": limit, "offset": offset}
|
||
|
||
if status and status != "all":
|
||
query += " WHERE l.status = :status"
|
||
params["status"] = status
|
||
|
||
query += " ORDER BY elo_rating DESC, l.current_price DESC LIMIT :limit OFFSET :offset"
|
||
result = db.execute(text(query), params)
|
||
listings = [row_to_listing(row) for row in result]
|
||
|
||
return [
|
||
RankingResponse(rank=offset + i + 1, listing=listing)
|
||
for i, listing in enumerate(listings)
|
||
]
|