fix

Author: AngeloGiacco

src/elevenlabs/conversational_ai/conversation.py

@@ -2,7 +2,7 @@
 import base64
 import json
 import threading
-from typing import Callable, Optional, Awaitable, Union, Any, Literal
+from typing import Callable, Optional, Awaitable, Union, Any, Literal, Dict, Tuple
 import asyncio
 from concurrent.futures import ThreadPoolExecutor
 from enum import Enum
@@ -119,7 +119,7 @@ class ClientTools:
     """
 
     def __init__(self) -> None:
-        self.tools: dict[str, tuple[Union[Callable[[dict], Any], Callable[[dict], Awaitable[Any]]], bool]] = {}
+        self.tools: Dict[str, Tuple[Union[Callable[[dict], Any], Callable[[dict], Awaitable[Any]]], bool]] = {}
         self.lock = threading.Lock()
         self._loop = None
         self._thread = None
@@ -196,6 +196,9 @@ def execute_tool(self, tool_name: str, parameters: dict, callback: Callable[[dic
         """
         if not self._running.is_set():
             raise RuntimeError("ClientTools event loop is not running")
+        
+        if self._loop is None:
+            raise RuntimeError("Event loop is not available")
 
         async def _execute_and_callback():
             try:

tests/test_convai.py

@@ -191,5 +191,5 @@ def test_conversation_with_contextual_update():
         conversation.wait_for_session_end()
 
     # Assertions
-    expected = json.dumps({"type": "contextual_update", "text": "User appears to be looking at pricing page"})
+    expected = json.dumps({"type": "contextual_update", "content": "User appears to be looking at pricing page"})
     mock_ws.send.assert_any_call(expected)