fix: parse user transcript events

Author: louisjoecodes

Sources/ElevenLabs/Auth/TokenService.swift

@@ -132,7 +132,7 @@ public struct TokenService: Sendable {
         components.queryItems = [
             URLQueryItem(name: "agent_id", value: agentId),
             URLQueryItem(name: "source", value: "swift_sdk"),
-            URLQueryItem(name: "version", value: SDKVersion.version)
+            URLQueryItem(name: "version", value: SDKVersion.version),
         ]
 
         guard let url = components.url else {

Sources/ElevenLabs/Conversation.swift

@@ -95,16 +95,16 @@ public final class Conversation: ObservableObject {
 
         deps.connectionManager.onAgentReady = { [weak self, auth, options] in
             Task { @MainActor in
-                guard let self else { 
-                    return 
+                guard let self else {
+                    return
                 }
                 // send conversation init exactly when the agent appears
                 try? await self.sendConversationInit(config: options.toConversationConfig())
                 // flip to .active once conversation init is sent
                 self.state = .active(.init(agentId: self.extractAgentId(from: auth)))
             }
         }
-        
+
         deps.connectionManager.onAgentDisconnected = { [weak self] in
             Task { @MainActor in
                 guard let self else { return }
@@ -149,7 +149,9 @@ public final class Conversation: ObservableObject {
 
     /// Send a text message to the agent.
     public func sendMessage(_ text: String) async throws {
-        guard state.isActive else { throw ConversationError.notConnected }
+        guard state.isActive else {
+            throw ConversationError.notConnected
+        }
         let event = OutgoingEvent.userMessage(UserMessageEvent(text: text))
         try await publish(event)
         appendLocalMessage(text)
@@ -303,7 +305,6 @@ public final class Conversation: ObservableObject {
         case let .tentativeAgentResponse(e):
             agentState = .speaking
             scheduleBackToListening()
-            appendTentativeAgent(e.tentativeResponse)
 
         case let .agentResponse(e):
             agentState = .speaking
@@ -348,7 +349,6 @@ public final class Conversation: ObservableObject {
                 case let .tentativeAgentResponse(e):
                     agentState = .speaking
                     scheduleBackToListening()
-                    appendTentativeAgent(e.tentativeResponse)
 
                 case let .agentResponse(e):
                     agentState = .speaking

Sources/ElevenLabs/Networking/ConnectionManager.swift

@@ -5,7 +5,7 @@ import LiveKit
 @MainActor
 class ConnectionManager {
     private var _room: Room?
-    
+
     private var readyDelegate: ReadyDelegate?
 
     var onAgentReady: (() -> Void)?
@@ -21,7 +21,7 @@ class ConnectionManager {
             onReady: { [weak self] in self?.onAgentReady?() },
             onDisconnected: { [weak self] in self?.onAgentDisconnected?() }
         )
-        readyDelegate = rd  // Keep strong reference
+        readyDelegate = rd // Keep strong reference
         room.add(delegate: rd)
 
         let (_, continuation) = AsyncStream<Data>.makeStream()
@@ -38,7 +38,7 @@ class ConnectionManager {
     func disconnect() async {
         await _room?.disconnect()
         _room = nil
-        readyDelegate = nil  // Clean up delegate reference
+        readyDelegate = nil // Clean up delegate reference
     }
 
     func dataEventsStream() -> AsyncStream<Data> {
@@ -64,32 +64,30 @@ class ConnectionManager {
         private var agentConnected = false
         private let onReady: () -> Void
         private let onDisconnected: () -> Void
-        
-        init(onReady: @escaping () -> Void, onDisconnected: @escaping () -> Void) { 
+
+        init(onReady: @escaping () -> Void, onDisconnected: @escaping () -> Void) {
             self.onReady = onReady
             self.onDisconnected = onDisconnected
         }
 
-        func room(_ room: Room, participantDidConnect participant: RemoteParticipant) {
-            guard !agentConnected else { 
-                return 
+        func room(_: Room, participantDidConnect _: RemoteParticipant) {
+            guard !agentConnected else {
+                return
             }
             agentConnected = true
             onReady()
         }
-        
-        func room(_ room: Room, participantDidDisconnect participant: RemoteParticipant) {
-            if agentConnected && room.remoteParticipants.isEmpty {
+
+        func room(_ room: Room, participantDidDisconnect _: RemoteParticipant) {
+            if agentConnected, room.remoteParticipants.isEmpty {
                 agentConnected = false
                 onDisconnected()
             }
         }
-        
-        func roomDidConnect(_ room: Room) {
-        }
-        
-        func room(_ room: Room, didUpdate connectionState: ConnectionState, from previousState: ConnectionState) {
-        }
+
+        func roomDidConnect(_: Room) {}
+
+        func room(_: Room, didUpdate _: ConnectionState, from _: ConnectionState) {}
     }
 }
 

Sources/ElevenLabs/Protocol/EventParser.swift

@@ -16,12 +16,16 @@ enum EventParser {
 
         switch type {
         case "user_transcript":
-            if let transcript = json["user_transcript"] as? String {
+            if let event = json["user_transcription_event"] as? [String: Any],
+               let transcript = event["user_transcript"] as? String
+            {
                 return .userTranscript(UserTranscriptEvent(transcript: transcript))
             }
 
         case "agent_response":
-            if let response = json["agent_response"] as? String {
+            if let event = json["agent_response_event"] as? [String: Any],
+               let response = event["agent_response"] as? String
+            {
                 return .agentResponse(AgentResponseEvent(response: response))
             }