update .

Author: lambiengcode

crates/rtc-manager/src/entities/room.rs

@@ -104,8 +104,8 @@ impl Room {
         // Add the shared UDP socket as a host candidate
         let addr = self.udp_socket.local_addr().unwrap();
         let candidate = Candidate::host(addr, "udp").expect("a host candidate");
-        rtc.add_local_candidate(candidate).unwrap();
-        info!("📡 Added host candidate: {}", addr);
+        rtc.add_local_candidate(candidate.clone()).unwrap();
+        info!("📡 Added host candidate: {:?}", candidate.to_sdp_string());
 
         // Create publisher with the new str0m-based architecture
         let publisher = Publisher::new(rtc, params.clone());
@@ -150,15 +150,16 @@ impl Room {
                     .map_err(|_| WebRTCError::FailedToCreateAnswer)?
             };
 
-            let answer_json = serde_json::to_string(&answer).unwrap();
-            info!("📄 SFU SDP answer created: {} chars", answer_json.len());
-
             // Create response with real SDP
             let response = JoinRoomResponse {
-                sdp: answer_json,
+                sdp: answer.to_sdp_string(),
                 is_recording: false,
             };
 
+            tokio::spawn(async move {
+                (params.callback)(false).await;
+            });
+
             info!(
                 "✅ SFU join room successful for participant: {}",
                 participant_id

crates/rtc-manager/src/rtc_manager.rs

@@ -1,5 +1,4 @@
 use std::sync::Arc;
-use std::time::Duration;
 
 use dashmap::DashMap;
 use parking_lot::RwLock;
@@ -108,7 +107,7 @@ impl RtcManager {
             room.join_room(params, room_id)?
         };
 
-        info!("✅ Join room completed for participant: {}", participant_id);
+        info!("✅ Join room completed for participant: {}", res.as_ref().unwrap().sdp.len());
         Ok(res)
     }
 

sfu/src/application/sfu_grpc_service.rs

@@ -1,23 +1,24 @@
 use std::sync::Arc;
 
 use parking_lot::RwLock;
-use tokio::sync::Mutex;
-use tonic::{Request, Response, Status};
-use waterbus_proto::{
-    AddPublisherCandidateRequest, AddSubscriberCandidateRequest, JoinRoomRequest, JoinRoomResponse,
-    LeaveRoomRequest, LeaveRoomResponse, MigratePublisherRequest, MigratePublisherResponse,
-    NewUserJoinedRequest, PublisherRenegotiationRequest,
-    PublisherRenegotiationResponse, SetCameraType, SetEnabledRequest, SetScreenSharingRequest,
-    SetSubscriberSdpRequest, StatusResponse, SubscribeHlsLiveStreamRequest,
-    SubscribeHlsLiveStreamResponse, SubscribeRequest, SubscribeResponse, SubscriberRenegotiateRequest, sfu_service_server::SfuService,
-};
 use rtc_manager::{
     models::{
         connection_type::ConnectionType,
         input_params::{IceCandidate, JoinedCallback, RenegotiationCallback, RtcManagerConfig},
     },
     rtc_manager::{JoinRoomReq, RtcManager},
 };
+use tokio::sync::Mutex;
+use tonic::{Request, Response, Status};
+use waterbus_proto::{
+    AddPublisherCandidateRequest, AddSubscriberCandidateRequest, JoinRoomRequest, JoinRoomResponse,
+    LeaveRoomRequest, LeaveRoomResponse, MigratePublisherRequest, MigratePublisherResponse,
+    NewUserJoinedRequest, PublisherRenegotiationRequest, PublisherRenegotiationResponse,
+    SetCameraType, SetEnabledRequest, SetScreenSharingRequest, SetSubscriberSdpRequest,
+    StatusResponse, SubscribeHlsLiveStreamRequest, SubscribeHlsLiveStreamResponse,
+    SubscribeRequest, SubscribeResponse, SubscriberRenegotiateRequest,
+    sfu_service_server::SfuService,
+};
 
 use super::dispacher_grpc_client::DispatcherGrpcClient;