eleven_multilingual_v2 long text error

[ke-dev]

Hello, eleven_multilingual_v2. If the Chinese character exceeds 20 characters, there will be no sound return. If the Chinese character is less than 20 characters, the sound can be received and played. Do you know what is going on? You can check it for me. This is my code. Thank you. `import asyncio import os import types import httpx

from realtime_ai_character.logger import get_logger from realtime_ai_character.utils import Singleton from realtime_ai_character.audio.text_to_speech.base import TextToSpeech

logger = get_logger(name) DEBUG = False ELEVEN_LABS_MULTILINGUAL_MODEL = 'eleven_multilingual_v2' if os.getenv( "ELEVEN_LABS_USE_V2", 'false').lower() in ('true', '1') else 'eleven_multilingual_v2'

config = types.SimpleNamespace(**{ 'chunk_size': 1024, 'url': 'https://api.elevenlabs.io/v1/text-to-speech/{voice_id}/stream', 'headers': { 'Accept': 'audio/mpeg', 'Content-Type': 'application/json', 'xi-api-key': os.environ['ELEVEN_LABS_API_KEY'] }, 'data': { 'model_id': 'eleven_monolingual_v1', 'voice_settings': { 'stability': 0.5, 'similarity_boost': 0.75 } } })

class ElevenLabs(Singleton, TextToSpeech): def init(self): super().init() logger.info("Initializing [ElevenLabs Text To Speech] voices...")

async def stream(self, text, websocket, tts_event: asyncio.Event, 
                 voice_id="21m00Tcm4TlvDq8ikWAM",
                 first_sentence=False, language='en-US') -> None:
    if DEBUG:
        return
    if voice_id == "":
        logger.info("voice_id is not found in .env file, using ElevenLabs default voice")
        voice_id = "21m00Tcm4TlvDq8ikWAM"
    headers = config.headers
    if language != 'en-US':
        config.data["model_id"] = 'eleven_multilingual_v2'
    data = {
        "text": text,
        **config.data,
    }
    url = config.url.format(voice_id=voice_id)
    if first_sentence:
        url = url + '?optimize_streaming_latency=4'
    async with httpx.AsyncClient() as client:
        response = await client.post(url, json=data, headers=headers)
        if response.status_code != 200:
            logger.error(
                f"ElevenLabs returns response {response.status_code}")
        async for chunk in response.aiter_bytes():
            await asyncio.sleep(0.1)
            if tts_event.is_set():
                # stop streaming audio
                break
            await websocket.send_bytes(chunk)

async def generate_audio(self, text, voice_id = "", language='en-US') -> bytes:
    if DEBUG:
        return
    if voice_id == "":
        logger.info("voice_id is not found in .env file, using ElevenLabs default voice")
        voice_id = "21m00Tcm4TlvDq8ikWAM"
    headers = config.headers
    if language != 'en-US':
        config.data["model_id"] = ELEVEN_LABS_MULTILINGUAL_MODEL
    data = {
        "text": text,
        **config.data,
    }
    # Change to non-streaming endpoint
    url = config.url.format(voice_id=voice_id).replace('/stream', '')
    async with httpx.AsyncClient() as client:
        response = await client.post(url, json=data, headers=headers)
        if response.status_code != 200:
            logger.error(f"ElevenLabs returns response {response.status_code}")
        # Get audio/mpeg from the response and return it
        return response.content`