fix and debug

Author: AngeloGiacco

src/elevenlabs/conversational_ai/conversation.py

@@ -13,7 +13,7 @@
 
 from ..base_client import BaseElevenLabs
 from ..version import __version__
-from .base_connection import ConnectionType
+from .base_connection import ConnectionType, BaseConnection
 from .connection_factory import create_connection, determine_connection_type
 
 
@@ -340,7 +340,7 @@ def __init__(
 
         self._conversation_id = None
         self._last_interrupt_id = 0
-        self._connection = None
+        self._connection: Optional[BaseConnection] = None
 
     def _get_wss_url(self):
         base_http_url = self.client._client_wrapper.get_base_url()

src/elevenlabs/conversational_ai/webrtc_connection.py

@@ -106,12 +106,19 @@ async def connect(self) -> None:
             # Enable microphone
             try:
                 await self._room.local_participant.set_microphone_enabled(True)
+            except AttributeError:
+                try:
+                    await self._room.local_participant.enable_microphone()
+                except AttributeError:
+                    self.debug({
+                        "type": "microphone_enable_error",
+                        "error": "Neither set_microphone_enabled nor enable_microphone methods available"
+                    })
             except Exception as e:
                 self.debug({
                     "type": "microphone_enable_error",
                     "error": str(e)
                 })
-                # Don't fail the connection for microphone issues
 
             # Send overrides if any
             if self.overrides:
@@ -319,7 +326,26 @@ async def set_microphone_enabled(self, enabled: bool) -> None:
         if not self._room or not self._room.local_participant:
             raise RuntimeError("Room not connected")
 
-        await self._room.local_participant.set_microphone_enabled(enabled)
+        try:
+            await self._room.local_participant.set_microphone_enabled(enabled)
+        except AttributeError:
+            try:
+                if enabled:
+                    await self._room.local_participant.enable_microphone()
+                else:
+                    await self._room.local_participant.disable_microphone()
+            except AttributeError:
+                self.debug({
+                    "type": "microphone_control_error",
+                    "enabled": enabled,
+                    "error": "Microphone control methods not available"
+                })
+        except Exception as e:
+            self.debug({
+                "type": "microphone_control_error",
+                "enabled": enabled,
+                "error": str(e)
+            })
 
     async def set_microphone_device(self, device_id: str) -> None:
         """Set the microphone input device."""