fix(react-sdk): close WebRTC transport on server disconnect

Author: iamprashant

package.json

@@ -1,6 +1,6 @@
 {
     "name": "@rapidaai/react",
-    "version": "1.1.78",
+    "version": "1.1.79",
     "description": "An easy to use react client for building generative ai application using Rapida platform.",
     "repository": {
         "type": "git",

src/agents/voice-agent.ts

@@ -117,6 +117,19 @@ export class VoiceAgent extends Agent {
         // console.log(`${LOG_PREFIX} callback -> onDisconnected`);
         this.switchToTextModeOnDisconnect();
       },
+      onConversationDisconnected: async () => {
+        const activeTransport = this.webrtcTransport;
+        this.webrtcTransport = null;
+        if (activeTransport) {
+          await activeTransport.close();
+        }
+        await this.disconnectAgent();
+        if (this.connectionState !== ConnectionState.Disconnected) {
+          this.connectionState = ConnectionState.Disconnected;
+          this.emit(AgentEvent.ConnectionStateEvent, ConnectionState.Disconnected);
+        }
+        this.switchToTextModeOnDisconnect();
+      },
       onError: (error) => {
         // console.log(`${LOG_PREFIX} callback -> onError`, error);
         this.emit(AgentEvent.ErrorEvent, "client", error.message || String(error));

src/audio/message-protocol-handler.ts

@@ -130,6 +130,8 @@ export class MessageProtocolHandler {
 
     // Disconnection (server requests disconnect)
     if (response.hasDisconnection()) {
+      const disconnection = response.getDisconnection();
+      await this.callbacks.onConversationDisconnected?.(disconnection?.toObject());
       this.callbacks.onDisconnected?.();
     }
 

src/clients/protos/artifacts

@@ -383,218 +383,6 @@ export namespace GetAllAssistantRequest {
   }
 }
 
-export class GetAllAssistantTelemetryRequest extends jspb.Message {
-  hasPaginate(): boolean;
-  clearPaginate(): void;
-  getPaginate(): common_pb.Paginate | undefined;
-  setPaginate(value?: common_pb.Paginate): void;
-
-  clearCriteriasList(): void;
-  getCriteriasList(): Array<common_pb.Criteria>;
-  setCriteriasList(value: Array<common_pb.Criteria>): void;
-  addCriterias(value?: common_pb.Criteria, index?: number): common_pb.Criteria;
-
-  hasAssistant(): boolean;
-  clearAssistant(): void;
-  getAssistant(): common_pb.AssistantDefinition | undefined;
-  setAssistant(value?: common_pb.AssistantDefinition): void;
-
-  serializeBinary(): Uint8Array;
-  toObject(includeInstance?: boolean): GetAllAssistantTelemetryRequest.AsObject;
-  static toObject(includeInstance: boolean, msg: GetAllAssistantTelemetryRequest): GetAllAssistantTelemetryRequest.AsObject;
-  static extensions: {[key: number]: jspb.ExtensionFieldInfo<jspb.Message>};
-  static extensionsBinary: {[key: number]: jspb.ExtensionFieldBinaryInfo<jspb.Message>};
-  static serializeBinaryToWriter(message: GetAllAssistantTelemetryRequest, writer: jspb.BinaryWriter): void;
-  static deserializeBinary(bytes: Uint8Array): GetAllAssistantTelemetryRequest;
-  static deserializeBinaryFromReader(message: GetAllAssistantTelemetryRequest, reader: jspb.BinaryReader): GetAllAssistantTelemetryRequest;
-}
-
-export namespace GetAllAssistantTelemetryRequest {
-  export type AsObject = {
-    paginate?: common_pb.Paginate.AsObject,
-    criteriasList: Array<common_pb.Criteria.AsObject>,
-    assistant?: common_pb.AssistantDefinition.AsObject,
-  }
-}
-
-export class TelemetryEvent extends jspb.Message {
-  getMessageid(): string;
-  setMessageid(value: string): void;
-
-  getAssistantid(): string;
-  setAssistantid(value: string): void;
-
-  getAssistantconversationid(): string;
-  setAssistantconversationid(value: string): void;
-
-  getProjectid(): string;
-  setProjectid(value: string): void;
-
-  getOrganizationid(): string;
-  setOrganizationid(value: string): void;
-
-  getName(): string;
-  setName(value: string): void;
-
-  getDataMap(): jspb.Map<string, string>;
-  clearDataMap(): void;
-  hasTime(): boolean;
-  clearTime(): void;
-  getTime(): google_protobuf_timestamp_pb.Timestamp | undefined;
-  setTime(value?: google_protobuf_timestamp_pb.Timestamp): void;
-
-  serializeBinary(): Uint8Array;
-  toObject(includeInstance?: boolean): TelemetryEvent.AsObject;
-  static toObject(includeInstance: boolean, msg: TelemetryEvent): TelemetryEvent.AsObject;
-  static extensions: {[key: number]: jspb.ExtensionFieldInfo<jspb.Message>};
-  static extensionsBinary: {[key: number]: jspb.ExtensionFieldBinaryInfo<jspb.Message>};
-  static serializeBinaryToWriter(message: TelemetryEvent, writer: jspb.BinaryWriter): void;
-  static deserializeBinary(bytes: Uint8Array): TelemetryEvent;
-  static deserializeBinaryFromReader(message: TelemetryEvent, reader: jspb.BinaryReader): TelemetryEvent;
-}
-
-export namespace TelemetryEvent {
-  export type AsObject = {
-    messageid: string,
-    assistantid: string,
-    assistantconversationid: string,
-    projectid: string,
-    organizationid: string,
-    name: string,
-    dataMap: Array<[string, string]>,
-    time?: google_protobuf_timestamp_pb.Timestamp.AsObject,
-  }
-}
-
-export class TelemetryMetric extends jspb.Message {
-  getContextid(): string;
-  setContextid(value: string): void;
-
-  getAssistantid(): string;
-  setAssistantid(value: string): void;
-
-  getAssistantconversationid(): string;
-  setAssistantconversationid(value: string): void;
-
-  getProjectid(): string;
-  setProjectid(value: string): void;
-
-  getOrganizationid(): string;
-  setOrganizationid(value: string): void;
-
-  getScope(): string;
-  setScope(value: string): void;
-
-  clearMetricsList(): void;
-  getMetricsList(): Array<common_pb.Metric>;
-  setMetricsList(value: Array<common_pb.Metric>): void;
-  addMetrics(value?: common_pb.Metric, index?: number): common_pb.Metric;
-
-  hasTime(): boolean;
-  clearTime(): void;
-  getTime(): google_protobuf_timestamp_pb.Timestamp | undefined;
-  setTime(value?: google_protobuf_timestamp_pb.Timestamp): void;
-
-  serializeBinary(): Uint8Array;
-  toObject(includeInstance?: boolean): TelemetryMetric.AsObject;
-  static toObject(includeInstance: boolean, msg: TelemetryMetric): TelemetryMetric.AsObject;
-  static extensions: {[key: number]: jspb.ExtensionFieldInfo<jspb.Message>};
-  static extensionsBinary: {[key: number]: jspb.ExtensionFieldBinaryInfo<jspb.Message>};
-  static serializeBinaryToWriter(message: TelemetryMetric, writer: jspb.BinaryWriter): void;
-  static deserializeBinary(bytes: Uint8Array): TelemetryMetric;
-  static deserializeBinaryFromReader(message: TelemetryMetric, reader: jspb.BinaryReader): TelemetryMetric;
-}
-
-export namespace TelemetryMetric {
-  export type AsObject = {
-    contextid: string,
-    assistantid: string,
-    assistantconversationid: string,
-    projectid: string,
-    organizationid: string,
-    scope: string,
-    metricsList: Array<common_pb.Metric.AsObject>,
-    time?: google_protobuf_timestamp_pb.Timestamp.AsObject,
-  }
-}
-
-export class TelemetryRecord extends jspb.Message {
-  hasEvent(): boolean;
-  clearEvent(): void;
-  getEvent(): TelemetryEvent | undefined;
-  setEvent(value?: TelemetryEvent): void;
-
-  hasMetric(): boolean;
-  clearMetric(): void;
-  getMetric(): TelemetryMetric | undefined;
-  setMetric(value?: TelemetryMetric): void;
-
-  getRecordCase(): TelemetryRecord.RecordCase;
-  serializeBinary(): Uint8Array;
-  toObject(includeInstance?: boolean): TelemetryRecord.AsObject;
-  static toObject(includeInstance: boolean, msg: TelemetryRecord): TelemetryRecord.AsObject;
-  static extensions: {[key: number]: jspb.ExtensionFieldInfo<jspb.Message>};
-  static extensionsBinary: {[key: number]: jspb.ExtensionFieldBinaryInfo<jspb.Message>};
-  static serializeBinaryToWriter(message: TelemetryRecord, writer: jspb.BinaryWriter): void;
-  static deserializeBinary(bytes: Uint8Array): TelemetryRecord;
-  static deserializeBinaryFromReader(message: TelemetryRecord, reader: jspb.BinaryReader): TelemetryRecord;
-}
-
-export namespace TelemetryRecord {
-  export type AsObject = {
-    event?: TelemetryEvent.AsObject,
-    metric?: TelemetryMetric.AsObject,
-  }
-
-  export enum RecordCase {
-    RECORD_NOT_SET = 0,
-    EVENT = 1,
-    METRIC = 2,
-  }
-}
-
-export class GetAllAssistantTelemetryResponse extends jspb.Message {
-  getCode(): number;
-  setCode(value: number): void;
-
-  getSuccess(): boolean;
-  setSuccess(value: boolean): void;
-
-  clearDataList(): void;
-  getDataList(): Array<TelemetryRecord>;
-  setDataList(value: Array<TelemetryRecord>): void;
-  addData(value?: TelemetryRecord, index?: number): TelemetryRecord;
-
-  hasError(): boolean;
-  clearError(): void;
-  getError(): common_pb.Error | undefined;
-  setError(value?: common_pb.Error): void;
-
-  hasPaginated(): boolean;
-  clearPaginated(): void;
-  getPaginated(): common_pb.Paginated | undefined;
-  setPaginated(value?: common_pb.Paginated): void;
-
-  serializeBinary(): Uint8Array;
-  toObject(includeInstance?: boolean): GetAllAssistantTelemetryResponse.AsObject;
-  static toObject(includeInstance: boolean, msg: GetAllAssistantTelemetryResponse): GetAllAssistantTelemetryResponse.AsObject;
-  static extensions: {[key: number]: jspb.ExtensionFieldInfo<jspb.Message>};
-  static extensionsBinary: {[key: number]: jspb.ExtensionFieldBinaryInfo<jspb.Message>};
-  static serializeBinaryToWriter(message: GetAllAssistantTelemetryResponse, writer: jspb.BinaryWriter): void;
-  static deserializeBinary(bytes: Uint8Array): GetAllAssistantTelemetryResponse;
-  static deserializeBinaryFromReader(message: GetAllAssistantTelemetryResponse, reader: jspb.BinaryReader): GetAllAssistantTelemetryResponse;
-}
-
-export namespace GetAllAssistantTelemetryResponse {
-  export type AsObject = {
-    code: number,
-    success: boolean,
-    dataList: Array<TelemetryRecord.AsObject>,
-    error?: common_pb.Error.AsObject,
-    paginated?: common_pb.Paginated.AsObject,
-  }
-}
-
 export class AssistantTelemetryProvider extends jspb.Message {
   getId(): string;
   setId(value: string): void;