from fastapi import APIRouter, Depends, HTTPException, status
from sqlalchemy.orm import Session
from app import models, schemas, database
import structlog

logger = structlog.get_logger()
router = APIRouter()

@router.get("/{book_id}", response_model=schemas.BookResponse)
async def get_book(book_id: int, db: Session = Depends(database.get_db)):
    book = db.query(models.Book).filter(models.Book.id == book_id).first()
    if not book:
        raise HTTPException(status_code=status.HTTP_404_NOT_FOUND, detail="Book not found")
    return book

async def check_availability(book: models.Book, db: Session) -> dict:
    for server in get_servers(db):
        try:
            async with create_client(server) as client:
                result = await client.lookup(book.hardcover_id)
                if result:
                    return {"available": True, "source": server.name}
        except Exception as e:
            logger.warning("availability_check_failed", server_id=server.id, error=str(e))
    return {"available": False}