import os


async def synthesize(text: str, voice: str) -> bytes:
    if os.environ.get("OPENAI_API_KEY"):
        from openai import AsyncOpenAI
        r = await AsyncOpenAI(api_key=os.environ["OPENAI_API_KEY"]).audio.speech.create(model="tts-1-hd", voice=voice, input=text, speed=1.05)
        return r.content
    from emergentintegrations.llm.openai import OpenAITextToSpeech
    return await OpenAITextToSpeech(api_key=os.environ["EMERGENT_LLM_KEY"]).generate_speech(text=text, model="tts-1-hd", voice=voice, speed=1.05)
