Revert "feat: add TURN-TCP support with server-driven config (#112)"

packages/sdk/package.json

@@ -35,7 +35,6 @@
     "test": "vitest unit",
     "test:e2e": "vitest e2e",
     "test:e2e:realtime": "vitest --config vitest.config.e2e-realtime.ts",
-    "test:e2e:turn-tcp": "vitest --config vitest.config.e2e-turn-tcp.ts",
     "typecheck": "tsc --noEmit",
     "format": "biome format --write",
     "format:check": "biome check",

packages/sdk/src/realtime/client.ts

@@ -96,8 +96,6 @@ const realTimeClientConnectOptionsSchema = z.object({
 });
 export type RealTimeClientConnectOptions = Omit<z.infer<typeof realTimeClientConnectOptionsSchema>, "model"> & {
   model: ModelDefinition | CustomModelDefinition;
-  iceServers?: RTCIceServer[];
-  iceTransportPolicy?: "tcp" | "udp" | "all";
 };
 
 export type Events = {
@@ -174,7 +172,7 @@ export const createRealTimeClient = (opts: RealTimeClientOptions) => {
       const { emitter: eventEmitter, emitOrBuffer, flush, stop } = createEventBuffer<Events>();
 
       webrtcManager = new WebRTCManager({
-        webrtcUrl: `${url}?api_key=${encodeURIComponent(apiKey)}&model=${encodeURIComponent(options.model.name)}${options.iceTransportPolicy ? `&ice_transport_policy=${encodeURIComponent(options.iceTransportPolicy)}` : ""}`,
+        webrtcUrl: `${url}?api_key=${encodeURIComponent(apiKey)}&model=${encodeURIComponent(options.model.name)}`,
         integration,
         logger,
         onDiagnostic: (name, data) => {
@@ -196,8 +194,6 @@ export const createRealTimeClient = (opts: RealTimeClientOptions) => {
         modelName: options.model.name,
         initialImage,
         initialPrompt,
-        iceServers: options.iceServers,
-        expectTurnConfig: !!options.iceTransportPolicy,
       });
 
       const manager = webrtcManager;

packages/sdk/src/realtime/types.ts

@@ -71,13 +71,6 @@ export type SessionIdMessage = {
   server_port: number;
 };
 
-export type TurnConfigMessage = {
-  type: "turn_config";
-  urls: string[];
-  username: string;
-  credential: string;
-};
-
 export type ConnectionState = "connecting" | "connected" | "generating" | "disconnected" | "reconnecting";
 
 // Incoming message types (from server)
@@ -92,8 +85,7 @@ export type IncomingWebRTCMessage =
   | GenerationStartedMessage
   | GenerationTickMessage
   | GenerationEndedMessage
-  | SessionIdMessage
-  | TurnConfigMessage;
+  | SessionIdMessage;
 
 // Outgoing message types (to server)
 export type OutgoingWebRTCMessage =

packages/sdk/src/realtime/webrtc-connection.ts

@@ -11,10 +11,9 @@ import type {
   PromptAckMessage,
   SessionIdMessage,
   SetImageAckMessage,
-  TurnConfigMessage,
 } from "./types";
 
-const DEFAULT_ICE_SERVERS: RTCIceServer[] = [{ urls: "stun:stun.l.google.com:19302" }];
+const ICE_SERVERS: RTCIceServer[] = [{ urls: "stun:stun.l.google.com:19302" }];
 const AVATAR_SETUP_TIMEOUT_MS = 30_000; // 30 seconds
 
 interface ConnectionCallbacks {
@@ -29,16 +28,13 @@ interface ConnectionCallbacks {
   initialPrompt?: { text: string; enhance?: boolean };
   logger?: Logger;
   onDiagnostic?: DiagnosticEmitter;
-  iceServers?: RTCIceServer[];
-  expectTurnConfig?: boolean;
 }
 
 type WsMessageEvents = {
   promptAck: PromptAckMessage;
   setImageAck: SetImageAckMessage;
   sessionId: SessionIdMessage;
   generationTick: GenerationTickMessage;
-  turnConfig: TurnConfigMessage;
 };
 
 const noopDiagnostic: DiagnosticEmitter = () => {};
@@ -50,7 +46,6 @@ export class WebRTCConnection {
   private connectionReject: ((error: Error) => void) | null = null;
   private logger: Logger;
   private emitDiagnostic: DiagnosticEmitter;
-  private turnServers: RTCIceServer[] = [];
   state: ConnectionState = "disconnected";
   websocketMessagesEmitter = mitt<WsMessageEvents>();
   constructor(private callbacks: ConnectionCallbacks = {}) {
@@ -164,22 +159,6 @@ export class WebRTCConnection {
         });
       }
 
-      // Phase 2.5: Wait for turn_config if not yet received.
-      // Only wait when the server is expected to send TURN config (iceTransportPolicy was set).
-      // turn_config arrives during Phase 2 but may race with set_image_ack.
-      if (this.callbacks.expectTurnConfig && this.turnServers.length === 0) {
-        let turnHandler: (() => void) | null = null;
-        await Promise.race([
-          new Promise<void>((resolve) => {
-            turnHandler = () => resolve();
-            this.websocketMessagesEmitter.on("turnConfig", turnHandler);
-          }),
-          new Promise<void>((resolve) => setTimeout(resolve, 2000)),
-          connectAbort,
-        ]);
-        if (turnHandler) this.websocketMessagesEmitter.off("turnConfig", turnHandler);
-      }
-
       // Phase 3: WebRTC handshake
       const handshakeStart = performance.now();
       await this.setupNewPeerConnection();
@@ -275,12 +254,6 @@ export class WebRTCConnection {
         return;
       }
 
-      if (msg.type === "turn_config") {
-        this.turnServers = [{ urls: msg.urls, username: msg.username, credential: msg.credential }];
-        this.websocketMessagesEmitter.emit("turnConfig", msg);
-        return;
-      }
-
       // All other messages require peer connection
       if (!this.pc) return;
 
@@ -438,11 +411,7 @@ export class WebRTCConnection {
       });
       this.pc.close();
     }
-    const iceServers: RTCIceServer[] = [
-      ...(this.callbacks.iceServers ?? DEFAULT_ICE_SERVERS),
-      ...this.turnServers,
-    ];
-    this.pc = new RTCPeerConnection({ iceServers });
+    this.pc = new RTCPeerConnection({ iceServers: ICE_SERVERS });
     this.setState("connecting");
 
     if (this.localStream) {
@@ -588,7 +557,6 @@ export class WebRTCConnection {
     this.ws?.close();
     this.ws = null;
     this.localStream = null;
-    this.turnServers = [];
     this.setState("disconnected");
   }
 

packages/sdk/src/realtime/webrtc-manager.ts

@@ -19,8 +19,6 @@ export interface WebRTCConfig {
   modelName?: string;
   initialImage?: string;
   initialPrompt?: { text: string; enhance?: boolean };
-  iceServers?: RTCIceServer[];
-  expectTurnConfig?: boolean;
 }
 
 const PERMANENT_ERRORS = [
@@ -68,8 +66,6 @@ export class WebRTCManager {
       initialPrompt: config.initialPrompt,
       logger: this.logger,
       onDiagnostic: config.onDiagnostic,
-      iceServers: config.iceServers,
-      expectTurnConfig: config.expectTurnConfig,
     });
   }
 

packages/sdk/vitest.config.ts

@@ -2,6 +2,6 @@ import { defineConfig } from "vitest/config";
 
 export default defineConfig({
   test: {
-    exclude: ["tests/e2e-realtime.test.ts", "tests/e2e-turn-tcp.test.ts"],
+    exclude: ["tests/e2e-realtime.test.ts"],
   },
 });