from fastapi import APIRouter, Depends
from sqlalchemy.ext.asyncio import AsyncSession

from app.auth import get_current_user
from app.categorizer import categorize_pending
from app.database import get_db

router = APIRouter(tags=["categorize"])


@router.post("/api/categorize")
async def run_categorize(db: AsyncSession = Depends(get_db), _user: dict = Depends(get_current_user)):
    count = await categorize_pending(db)
    return {"categorized": count}