removed the deprecated events

Author: xianshijing-lk

include/livekit/room_delegate.h

@@ -244,18 +244,6 @@ class RoomDelegate {
    */
   virtual void onSipDtmfReceived(Room &, const SipDtmfReceivedEvent &) {}
 
-  /**
-   * Called when a transcription result is received.
-   */
-  virtual void onTranscriptionReceived(Room &,
-                                       const TranscriptionReceivedEvent &) {}
-
-  /**
-   * Called when a chat message is received.
-   */
-  virtual void onChatMessageReceived(Room &, const ChatMessageReceivedEvent &) {
-  }
-
   // ------------------------------------------------------------------
   // Data streams
   // ------------------------------------------------------------------

include/livekit/room_event_types.h

@@ -105,29 +105,6 @@ enum class DisconnectReason {
   MediaFailure
 };
 
-/**
- * A chat message associated with the room.
- */
-struct ChatMessageData {
-  /** Unique ID of the message. */
-  std::string id;
-
-  /** Timestamp (ms since Unix epoch). */
-  std::int64_t timestamp = 0;
-
-  /** Message body. */
-  std::string message;
-
-  /** Optional timestamp when the message was edited (ms since Unix epoch). */
-  std::optional<std::int64_t> edit_timestamp;
-
-  /** True if the message has been deleted. */
-  bool deleted = false;
-
-  /** True if the message was generated (e.g. by an AI or system). */
-  bool generated = false;
-};
-
 /**
  * Application-level user data carried in a data packet.
  */
@@ -647,21 +624,6 @@ struct Transcription {
   std::vector<TranscriptionSegment> segments;
 };
 
-/**
- * Fired when a transcription result is received.
- */
-struct TranscriptionReceivedEvent {
-  /** Transcription segments for this update. */
-  std::vector<TranscriptionSegment> segments;
-
-  /** Local or remote participant associated with these segments (owned by
-   * Room). */
-  Participant *participant = nullptr;
-
-  /** Publication of the track used for transcription, if available. */
-  std::shared_ptr<TrackPublication> publication;
-};
-
 /**
  * Fired when the room's connection state changes.
  */
@@ -794,15 +756,4 @@ struct E2eeStateChangedEvent {
   EncryptionState state = EncryptionState::New;
 };
 
-/**
- * Fired when a chat message is received.
- */
-struct ChatMessageReceivedEvent {
-  /** Chat message payload. */
-  ChatMessageData message;
-
-  /** Identity of the participant who sent the message. */
-  std::string participant_identity;
-};
-
 } // namespace livekit

src/room.cpp

@@ -773,39 +773,7 @@ void Room::OnEvent(const FfiEvent &event) {
       // ------------------------------------------------------------------------
 
     case proto::RoomEvent::kTranscriptionReceived: {
-      TranscriptionReceivedEvent ev;
-      {
-        std::lock_guard<std::mutex> guard(lock_);
-        const auto &tr = re.transcription_received();
-        for (const auto &s : tr.segments()) {
-          TranscriptionSegment seg;
-          seg.id = s.id();
-          seg.text = s.text();
-          seg.final = s.final();
-          seg.start_time = s.start_time();
-          seg.end_time = s.end_time();
-          seg.language = s.language();
-          ev.segments.push_back(std::move(seg));
-        }
-
-        Participant *participant = nullptr;
-        if (!tr.participant_identity().empty()) {
-          const std::string &identity = tr.participant_identity();
-          if (local_participant_ &&
-              local_participant_->identity() == identity) {
-            participant = local_participant_.get();
-          } else {
-            auto it = remote_participants_.find(identity);
-            if (it != remote_participants_.end()) {
-              participant = it->second.get();
-            }
-          }
-        }
-        ev.participant = participant;
-        ev.publication = participant->findTrackPublication(tr.track_sid());
-      }
-
-      delegate_snapshot->onTranscriptionReceived(*this, ev);
+      // Deprecated event, do nothing.
       break;
     }
 
@@ -901,8 +869,7 @@ void Room::OnEvent(const FfiEvent &event) {
       break;
     }
     case proto::RoomEvent::kChatMessage: {
-      auto ev = fromProto(re.chat_message());
-      delegate_snapshot->onChatMessageReceived(*this, ev);
+      // Deprecated event, do nothing.
       break;
     }
     case proto::RoomEvent::kStreamHeaderReceived: {

src/room_proto_converter.cpp

@@ -69,23 +69,6 @@ DisconnectReason toDisconnectReason(proto::DisconnectReason /*in*/) {
 
 // --------- basic helper conversions ---------
 
-ChatMessageData fromProto(const proto::ChatMessage &in) {
-  ChatMessageData out;
-  out.id = in.id();
-  out.timestamp = in.timestamp();
-  out.message = in.message();
-  if (in.has_edit_timestamp()) {
-    out.edit_timestamp = in.edit_timestamp();
-  }
-  if (in.has_deleted()) {
-    out.deleted = in.deleted();
-  }
-  if (in.has_generated()) {
-    out.generated = in.generated();
-  }
-  return out;
-}
-
 UserPacketData fromProto(const proto::UserPacket &in) {
   UserPacketData out;
   // TODO, double check following code is safe
@@ -299,13 +282,6 @@ RoomMovedEvent roomMovedFromProto(const proto::RoomInfo &in) {
   return ev;
 }
 
-ChatMessageReceivedEvent fromProto(const proto::ChatMessageReceived &in) {
-  ChatMessageReceivedEvent ev;
-  ev.message = fromProto(in.message());
-  ev.participant_identity = in.participant_identity();
-  return ev;
-}
-
 // ---------------- Room Options ----------------
 
 proto::AudioEncoding toProto(const AudioEncodingOptions &in) {
@@ -420,21 +396,6 @@ TranscriptionSegment fromProto(const proto::TranscriptionSegment &in) {
   return out;
 }
 
-Transcription fromProto(const proto::TranscriptionReceived &in) {
-  Transcription out;
-  if (in.has_participant_identity()) {
-    out.participant_identity = in.participant_identity();
-  }
-  if (in.has_track_sid()) {
-    out.track_sid = in.track_sid();
-  }
-  out.segments.reserve(in.segments_size());
-  for (const auto &pseg : in.segments()) {
-    out.segments.push_back(fromProto(pseg));
-  }
-  return out;
-}
-
 UserDataPacketEvent userDataPacketFromProto(const proto::DataPacketReceived &in,
                                             RemoteParticipant *participant) {
   UserDataPacketEvent ev;

src/room_proto_converter.h

@@ -33,7 +33,6 @@ ConnectionState toConnectionState(proto::ConnectionState in);
 DataPacketKind toDataPacketKind(proto::DataPacketKind in);
 DisconnectReason toDisconnectReason(proto::DisconnectReason in);
 
-ChatMessageData fromProto(const proto::ChatMessage &in);
 UserPacketData fromProto(const proto::UserPacket &in);
 SipDtmfData fromProto(const proto::SipDTMF &in);
 RoomInfoData fromProto(const proto::RoomInfo &in);
@@ -69,8 +68,6 @@ RoomUpdatedEvent
 roomUpdatedFromProto(const proto::RoomInfo &in);              // room_updated
 RoomMovedEvent roomMovedFromProto(const proto::RoomInfo &in); // moved
 
-ChatMessageReceivedEvent fromProto(const proto::ChatMessageReceived &in);
-
 // --------- room options conversions ---------
 
 proto::AudioEncoding toProto(const AudioEncodingOptions &in);
@@ -87,9 +84,6 @@ TrackPublishOptions fromProto(const proto::TrackPublishOptions &in);
 proto::TranscriptionSegment toProto(const TranscriptionSegment &in);
 TranscriptionSegment fromProto(const proto::TranscriptionSegment &in);
 
-proto::TranscriptionReceived toProto(const TranscriptionReceivedEvent &in);
-Transcription fromProto(const proto::TranscriptionReceived &in);
-
 // --------- room Data Packet conversions ---------
 
 UserDataPacketEvent userDataPacketFromProto(const proto::DataPacketReceived &in,