fix syntax to create inputstream

Author: chenosaurus

livekit-rtc/livekit/rtc/media_devices.py

@@ -16,6 +16,8 @@
 
 import asyncio
 from dataclasses import dataclass
+import inspect
+import logging
 from typing import Any, AsyncIterator, Optional
 
 import numpy as np
@@ -397,15 +399,35 @@ def _input_callback(indata: np.ndarray, frame_count: int, time_info: Any, status
             channels_arg = 1
             mapping = [int(input_channel_index) + 1]
 
-        input_stream = sd.InputStream(
-            callback=_input_callback,
-            dtype="int16",
-            channels=channels_arg,
-            device=input_device,
-            samplerate=self._in_sr,
-            blocksize=self._blocksize,
-            mapping=mapping,
-        )
+        # Build kwargs and conditionally include 'mapping' based on sounddevice version
+        stream_kwargs: dict[str, Any] = {
+            "callback": _input_callback,
+            "dtype": "int16",
+            "channels": channels_arg,
+            "device": input_device,
+            "samplerate": self._in_sr,
+            "blocksize": self._blocksize,
+        }
+        try:
+            init_params = inspect.signature(sd.InputStream.__init__).parameters
+            if "mapping" in init_params and mapping is not None:
+                stream_kwargs["mapping"] = mapping
+            elif mapping is not None:
+                logging.getLogger(__name__).warning(
+                    "sounddevice.InputStream does not support 'mapping' in this version; "
+                    "ignoring input_channel_index=%s",
+                    input_channel_index,
+                )
+        except Exception:
+            # If inspection fails for any reason, fall back without mapping
+            if mapping is not None:
+                logging.getLogger(__name__).warning(
+                    "Unable to inspect sounddevice.InputStream.__init__; "
+                    "ignoring input_channel_index=%s",
+                    input_channel_index,
+                )
+
+        input_stream = sd.InputStream(**stream_kwargs)
         input_stream.start()
 
         async def _pump() -> None: