Function on_message

evi/evi-python-quickstart/quickstart.py:27–38

(message: SubscribeEvent, stream: Stream)

async def on_message(message: SubscribeEvent, stream: Stream) -> None:
    if message.type == "chat_metadata":
        log(f"<{message.type}> Chat ID: {message.chat_id}, Chat Group ID: {message.chat_group_id}")
    elif message.type == "user_message" or message.type == "assistant_message":
        log(f"{message.message.role}: {message.message.content}")
        print_emotions(extract_top_n_emotions(dict(message.models.prosody and message.models.prosody.scores or {}), 3))
    elif message.type == "audio_output":
        await stream.put(base64.b64decode(message.data.encode("utf-8")))
    elif message.type == "error":
        raise RuntimeError(f"Received error message from Hume websocket ({message.code}): {message.message}")
    else:
        log(f"<{message.type}>")


async def main() -> None: