34 lines
1.0 KiB
Python
34 lines
1.0 KiB
Python
|
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,
|
||
|
|
)
|