use correct codec

Author: maxkahan

examples/other_examples/openai_realtime_webrtc/openai_realtime_example.py

@@ -16,7 +16,7 @@
 from vision_agents.core.agents import Agent
 from getstream import AsyncStream
 
-logging.basicConfig(level=logging.WARNING)
+logging.basicConfig(level=logging.INFO)
 logger = logging.getLogger(__name__)
 
 load_dotenv()

plugins/getstream/vision_agents/plugins/getstream/stream_edge_transport.py

@@ -106,6 +106,11 @@ async def _on_track_published(self, event: sfu_events.TrackPublishedEvent):
         track_key = (user_id, session_id, track_type_int)
         is_agent_track = (user_id == self.agent_user_id)
 
+        # Skip processing the agent's own tracks - we don't subscribe to them
+        if is_agent_track:
+            self.logger.debug(f"Skipping agent's own track: {track_type_int} from {user_id}")
+            return
+
         # First check if track already exists in map (e.g., from previous unpublish/republish)
         if track_key in self._track_map:
             self._track_map[track_key]["published"] = True
@@ -115,15 +120,14 @@ async def _on_track_published(self, event: sfu_events.TrackPublishedEvent):
             )
 
             # Emit TrackAddedEvent so agent can switch to this track
-            if not is_agent_track:
-                self.events.send(
-                    events.TrackAddedEvent(
-                        plugin_name="getstream",
-                        track_id=track_id,
-                        track_type=track_type_int,
-                        user=event.participant,
-                    )
+            self.events.send(
+                events.TrackAddedEvent(
+                    plugin_name="getstream",
+                    track_id=track_id,
+                    track_type=track_type_int,
+                    user=event.participant,
                 )
+            )
             return
 
         # Wait for pending track to be populated (with 10 second timeout)
@@ -161,17 +165,15 @@ async def _on_track_published(self, event: sfu_events.TrackPublishedEvent):
                 f"Trackmap published: {track_type_int} from {user_id}, track_id: {track_id} (waited {elapsed:.2f}s)"
             )
 
-            # Only emit TrackAddedEvent for remote participants, not for agent's own tracks
-            if not is_agent_track:
-                # NOW spawn TrackAddedEvent with correct type
-                self.events.send(
-                    events.TrackAddedEvent(
-                        plugin_name="getstream",
-                        track_id=track_id,
-                        track_type=track_type_int,
-                        user=event.participant,
-                    )
+            # Emit TrackAddedEvent with correct type
+            self.events.send(
+                events.TrackAddedEvent(
+                    plugin_name="getstream",
+                    track_id=track_id,
+                    track_type=track_type_int,
+                    user=event.participant,
                 )
+            )
         else:
             raise TimeoutError(
                 f"Timeout waiting for pending track: {track_type_int} ({expected_kind}) from user {user_id}, "
@@ -395,10 +397,10 @@ async def open_demo(self, call: Call) -> str:
             "token": token,
             "skip_lobby": "true",
             "user_name": name,
-            "video_encoder": "vp8",
-            "bitrate": 12000000,
+            "video_encoder": "h264",  # Use H.264 instead of VP8 for better compatibility
+            "bitrate": 12000000,  
             "w": 1920,
-            "h": 1080,
+            "h": 1080,   
             "channel_type": self.channel_type,
         }