src/kittykat_agent/queue/router.py

from fastapi import APIRouter, Depends
from logger import logger
from config.firebase import get_user_token
from kittykat_agent.core.utils import BaseApiResponse
from kittykat_agent.queue.models import QueueItemDeleteRequest
from kittykat_agent.queue.service import QueueService


router = APIRouter()


@router.delete("/queue", response_model=BaseApiResponse)
async def delete_queue_items(
    request: QueueItemDeleteRequest,
    user_id=Depends(get_user_token),
):
    try:
        logger.info(f"Deleting queue items for user {user_id}: {request.ids}")

        await QueueService.delete_queue_items(
            user_id=user_id,
            queue_item_ids=request.ids
        )
        return BaseApiResponse(
            status_code=200,
            message="Queue items deleted successfully",
            data=None
        )

    except Exception as e:
        logger.error(f"Error creating moodboard: {str(e)}")
        return BaseApiResponse(
            status_code=500,
            message=f"Failed to create moodboard: {str(e)}",
            data=None
        )