Move realtime to root level

Author: yadavsahil197

README.md

@@ -187,7 +187,7 @@ text.
 
 ```python
 from together import AsyncTogether
-from together.lib.realtime import TranscriptDelta, TranscriptCompleted
+from together.realtime import TranscriptDelta, TranscriptCompleted
 
 client = AsyncTogether()
 

examples/realtime_failover.py

@@ -23,7 +23,7 @@
 from pathlib import Path
 
 from together import AsyncTogether
-from together.lib.realtime import (
+from together.realtime import (
     BufferGap,
     SessionStarted,
     TranscriptDelta,

examples/realtime_transcription.py

@@ -19,7 +19,7 @@
 from pathlib import Path
 
 from together import AsyncTogether
-from together.lib.realtime import (
+from together.realtime import (
     SessionStarted,
     TranscriptDelta,
     TranscriptCompleted,

src/together/realtime.py

@@ -0,0 +1,73 @@
+"""Public types for the realtime transcription API (`client.beta.realtime`).
+
+Import events, options, and exceptions from here:
+
+    from together.realtime import TranscriptCompleted, RealtimeConnectionError
+
+This module is the stable import surface; the implementation lives in
+`together.lib.realtime` and may be reorganized without notice.
+"""
+
+from .lib.realtime import (
+    BufferGap as BufferGap,
+    TurnEvent as TurnEvent,
+    Reconnected as Reconnected,
+    Reconnecting as Reconnecting,
+    UnknownEvent as UnknownEvent,
+    BufferOptions as BufferOptions,
+    RealtimeError as RealtimeError,
+    SessionStarted as SessionStarted,
+    TranscriptDelta as TranscriptDelta,
+    ReconnectOptions as ReconnectOptions,
+    TranscriptFailed as TranscriptFailed,
+    EchoResponseEvent as EchoResponseEvent,
+    RealtimeErrorInfo as RealtimeErrorInfo,
+    TurnDetectionParam as TurnDetectionParam,
+    RealtimeServerEvent as RealtimeServerEvent,
+    SessionCreatedEvent as SessionCreatedEvent,
+    TranscriptCompleted as TranscriptCompleted,
+    RealtimeSessionError as RealtimeSessionError,
+    RealtimeSessionEvent as RealtimeSessionEvent,
+    RealtimeConnectionError as RealtimeConnectionError,
+    TranscriptionDeltaEvent as TranscriptionDeltaEvent,
+    RealtimeIdleTimeoutError as RealtimeIdleTimeoutError,
+    TranscriptionFailedEvent as TranscriptionFailedEvent,
+    RealtimeInvalidStateError as RealtimeInvalidStateError,
+    RealtimeBufferOverflowError as RealtimeBufferOverflowError,
+    TranscriptionCompletedEvent as TranscriptionCompletedEvent,
+    InputAudioBufferProcessedEvent as InputAudioBufferProcessedEvent,
+)
+
+__all__ = [
+    # events (wire)
+    "RealtimeServerEvent",
+    "SessionCreatedEvent",
+    "TranscriptionDeltaEvent",
+    "TranscriptionCompletedEvent",
+    "TranscriptionFailedEvent",
+    "TurnEvent",
+    "InputAudioBufferProcessedEvent",
+    "EchoResponseEvent",
+    "UnknownEvent",
+    "RealtimeErrorInfo",
+    # events (normalized session)
+    "RealtimeSessionEvent",
+    "SessionStarted",
+    "TranscriptDelta",
+    "TranscriptCompleted",
+    "TranscriptFailed",
+    "Reconnecting",
+    "Reconnected",
+    "BufferGap",
+    # options
+    "TurnDetectionParam",
+    "ReconnectOptions",
+    "BufferOptions",
+    # exceptions
+    "RealtimeError",
+    "RealtimeConnectionError",
+    "RealtimeSessionError",
+    "RealtimeIdleTimeoutError",
+    "RealtimeBufferOverflowError",
+    "RealtimeInvalidStateError",
+]

tests/unit/test_realtime_wiring.py

@@ -28,6 +28,17 @@ def test_public_lib_surface_importable() -> None:
         assert getattr(rt, name) is not None
 
 
+def test_root_realtime_module_reexports_public_surface() -> None:
+    """`together.realtime` is the stable public import path; it must expose
+    everything the lib package exports (a regen or refactor that drops the
+    root shim or lets it drift fails here)."""
+    import together.realtime as public
+    import together.lib.realtime as lib
+
+    for name in lib.__all__:
+        assert getattr(public, name) is getattr(lib, name), name
+
+
 def test_url_and_header_derivation() -> None:
     import httpx