import logging
from typing import Optional

from fastapi import APIRouter, Depends, File, Form, HTTPException, Request, UploadFile
from sqlmodel import Session

from core.database import get_session
from core.speech_service import WhisperSpeechService
from services.speech_transcribe_service import transcribe_bot_speech_upload

router = APIRouter()
logger = logging.getLogger("dashboard.backend")


@router.post("/api/bots/{bot_id}/speech/transcribe")
async def transcribe_bot_speech(
    bot_id: str,
    request: Request,
    file: UploadFile = File(...),
    language: Optional[str] = Form(None),
    session: Session = Depends(get_session),
):
    speech_service = getattr(request.app.state, "speech_service", None)
    if not isinstance(speech_service, WhisperSpeechService):
        raise HTTPException(status_code=500, detail="Speech service is not initialized")
    return await transcribe_bot_speech_upload(
        session,
        bot_id,
        upload=file,
        language=language,
        speech_service=speech_service,
        logger=logger,
    )