pass participant in all relevant methods

Author: tbarbugli

getstream/video/rtc/track_util.py

@@ -97,8 +97,8 @@ class PcmData:
         dts: The decode timestamp of the audio data.
         time_base: The time base for converting timestamps to seconds.
         channels: Number of audio channels (1=mono, 2=stereo)
+        participant: The participant context for this audio data.
     """
-    participant: Any = None
 
     def __init__(
         self,
@@ -109,6 +109,7 @@ def __init__(
         dts: Optional[int] = None,
         time_base: Optional[float] = None,
         channels: int = 1,
+        participant: Any = None,
     ):
         """
         Initialize PcmData.
@@ -121,6 +122,7 @@ def __init__(
             dts: The decode timestamp of the audio data
             time_base: The time base for converting timestamps to seconds
             channels: Number of audio channels (1=mono, 2=stereo)
+            participant: The participant context for this audio data
 
         Raises:
             TypeError: If samples dtype does not match the declared format
@@ -168,6 +170,7 @@ def __init__(
         self.dts: Optional[int] = dts
         self.time_base: Optional[float] = time_base
         self.channels: int = channels
+        self.participant: Any = participant
 
     @property
     def stereo(self) -> bool:
@@ -530,9 +533,7 @@ def resample(
         resampler = Resampler(
             format=self.format, sample_rate=target_sample_rate, channels=target_channels
         )
-        pcm = resampler.resample(self)
-        pcm.participant = self.participant
-        return pcm
+        return resampler.resample(self)
 
     def to_bytes(self) -> bytes:
         """Return interleaved PCM bytes.
@@ -655,6 +656,7 @@ def to_float32(self) -> "PcmData":
             dts=self.dts,
             time_base=self.time_base,
             channels=self.channels,
+            participant=self.participant,
         )
 
     def to_int16(self) -> "PcmData":
@@ -718,6 +720,7 @@ def to_int16(self) -> "PcmData":
             dts=self.dts,
             time_base=self.time_base,
             channels=self.channels,
+            participant=self.participant,
         )
 
     def append(self, other: "PcmData") -> "PcmData":
@@ -878,6 +881,7 @@ def copy(self) -> "PcmData":
             dts=self.dts,
             time_base=self.time_base,
             channels=self.channels,
+            participant=self.participant,
         )
 
     def clear(self) -> None:
@@ -1292,6 +1296,7 @@ def tail(
             dts=self.dts,
             time_base=self.time_base,
             channels=self.channels,
+            participant=self.participant,
         )
 
     def head(
@@ -1400,6 +1405,7 @@ def head(
             dts=self.dts,
             time_base=self.time_base,
             channels=self.channels,
+            participant=self.participant,
         )
 
 
@@ -1485,7 +1491,7 @@ def resample(self, pcm: PcmData) -> PcmData:
             samples = self._adjust_format(samples, current_format, self.format)
             current_format = self.format
 
-        # Create new PcmData with resampled audio, preserving timestamps
+        # Create new PcmData with resampled audio, preserving timestamps and participant
         return PcmData(
             samples=samples,
             sample_rate=self.sample_rate,
@@ -1494,6 +1500,7 @@ def resample(self, pcm: PcmData) -> PcmData:
             pts=pcm.pts,
             dts=pcm.dts,
             time_base=pcm.time_base,
+            participant=pcm.participant,
         )
 
     def _resample_1d(