Refactor/session transport config (#344)

src/services/agent-manager/connect-to-manager.test.ts

@@ -611,7 +611,9 @@ describe('connect-to-manager', () => {
                 expressiveAgent,
                 {
                     version: StreamApiVersion.V2,
-                    transport_provider: TransportProvider.Livekit,
+                    transport: {
+                        provider: TransportProvider.Livekit,
+                    },
                 },
                 expect.not.objectContaining({
                     chatId: expect.anything(),

src/services/agent-manager/connect-to-manager.ts

@@ -34,7 +34,9 @@ import { createChat } from '../chat';
 const ChatPrefix = 'cht';
 function getAgentStreamV2Options(): CreateSessionV2Options {
     return {
-        transport_provider: TransportProvider.Livekit,
+        transport: {
+            provider: TransportProvider.Livekit,
+        },
     };
 }
 

src/services/streaming-manager/factory.test.ts

@@ -92,7 +92,9 @@ describe('createStreamingManager', () => {
         });
 
         const v2StreamOptions: CreateSessionV2Options = {
-            transport_provider: TransportProvider.Livekit,
+            transport: {
+                provider: TransportProvider.Livekit,
+            },
             chat_persist: true,
         };
 
@@ -115,7 +117,9 @@ describe('createStreamingManager', () => {
         });
 
         const v2StreamOptions: CreateSessionV2Options = {
-            transport_provider: TransportProvider.Livekit,
+            transport: {
+                provider: TransportProvider.Livekit,
+            },
             chat_persist: true,
         };
 

src/services/streaming-manager/factory.ts

@@ -34,12 +34,12 @@ export async function createStreamingManager(
         case StreamApiVersion.V2: {
             const { version, ...createStreamOptions } = streamOptions;
 
-            switch (createStreamOptions.transport_provider) {
+            switch (createStreamOptions.transport.provider) {
                 case TransportProvider.Livekit:
                     const { createLiveKitStreamingManager } = await import('./livekit-manager');
                     return createLiveKitStreamingManager(agentId, createStreamOptions, options);
                 default:
-                    throw new Error(`Unsupported transport provider: ${createStreamOptions.transport_provider}`);
+                    throw new Error(`Unsupported transport provider: ${createStreamOptions.transport.provider}`);
             }
         }
 

src/services/streaming-manager/livekit-manager.test.ts

@@ -5,6 +5,7 @@ import {
     StreamEvents,
     StreamingManagerOptions,
     StreamingState,
+    TransportProvider,
 } from '../../types/index';
 import { createLiveKitStreamingManager } from './livekit-manager';
 
@@ -268,7 +269,9 @@ describe('LiveKit Streaming Manager - Microphone Stream', () => {
         agentId = TEST_AGENT_ID;
         sessionOptions = {
             chat_persist: true,
-            transport_provider: 'livekit' as any,
+            transport: {
+                provider: TransportProvider.Livekit,
+            },
         };
         options = StreamingManagerOptionsFactory.build();
     });
@@ -809,7 +812,9 @@ describe('LiveKit Streaming Manager - Camera Stream', () => {
         agentId = TEST_AGENT_ID;
         sessionOptions = {
             chat_persist: true,
-            transport_provider: 'livekit' as any,
+            transport: {
+                provider: TransportProvider.Livekit,
+            },
         };
         options = StreamingManagerOptionsFactory.build();
     });
@@ -1034,7 +1039,9 @@ describe('LiveKit Streaming Manager - Disconnect Behavior', () => {
         agentId = TEST_AGENT_ID;
         sessionOptions = {
             chat_persist: true,
-            transport_provider: 'livekit' as any,
+            transport: {
+                provider: TransportProvider.Livekit,
+            },
         };
         options = StreamingManagerOptionsFactory.build();
     });
@@ -1126,7 +1133,9 @@ describe('LiveKit Streaming Manager - Tool Events and Activity State', () => {
         agentId = TEST_AGENT_ID;
         sessionOptions = {
             chat_persist: true,
-            transport_provider: 'livekit' as any,
+            transport: {
+                provider: TransportProvider.Livekit,
+            },
         };
         options = StreamingManagerOptionsFactory.build();
     });

src/services/streaming-manager/livekit-manager.ts

@@ -12,7 +12,6 @@ import {
     StreamType,
     ToolCallingPayload,
     ToolResultPayload,
-    TransportProvider,
 } from '@sdk/types';
 import { ChatProgress } from '@sdk/types/entities/agents/manager';
 import { noop } from '@sdk/utils';
@@ -133,7 +132,7 @@ export async function createLiveKitStreamingManager<T extends CreateSessionV2Opt
 
     try {
         const streamResponse = await streamApi.createStream({
-            transport_provider: TransportProvider.Livekit,
+            transport: sessionOptions.transport,
             chat_persist: sessionOptions.chat_persist ?? true,
         });
 

src/types/stream/streams-v2.ts

@@ -3,7 +3,9 @@ export enum TransportProvider {
 }
 
 export interface CreateSessionV2Options {
-    transport_provider: TransportProvider.Livekit;
+    transport: {
+        provider: TransportProvider.Livekit;
+    };
     chat_persist?: boolean;
 }