# import logging
# from fastapi import APIRouter
# from pydantic import BaseModel
# from sqlalchemy import text

# from app.schemas import ResponseWrapper
# from app.models.connection import get_async_db
# from app.services.predict_price import predict_30_days_data

# router = APIRouter()

# logger = logging.getLogger(__name__)


# class PricingRequest(BaseModel):
#     prices: dict
#     rooms: dict

# async def fetch_rooms(keys: list):
#     async with get_async_db() as db:
#         query = text("""
#             SELECT product_id, product_name, type_id
#             FROM `products`
#             WHERE type_id in :keys
#         """)
#         result = await db.execute(query, {"keys": tuple(keys)})
#         rooms = result.fetchall()
#         return { room.type_id: room.product_name for room in rooms}


# @router.get(
#     "/pricing",
#     tags=["Pricing"],
#     response_model=ResponseWrapper[PricingRequest],
#     summary="Predict pricing for 30 days.",
#     status_code=200,
# )
# async def predict_pricing() -> ResponseWrapper[PricingRequest]:
#     logger.info("Started GET /pricing")
#     result = await predict_30_days_data()
#     keys = result.keys()
#     rooms = await fetch_rooms(keys)
#     return ResponseWrapper(status=True, message="OK", data=PricingRequest(prices=result, rooms=rooms))