From 451397cbf01404accbebda0bf164ce63f0a9af5f Mon Sep 17 00:00:00 2001 From: Stuart Woodbury Date: Thu, 9 Nov 2023 10:42:05 -0500 Subject: [PATCH] fix signalling - use announce --- .../warp-blink-wrtc/src/blink_impl/blink_controller.rs | 8 +++----- 1 file changed, 3 insertions(+), 5 deletions(-) diff --git a/extensions/warp-blink-wrtc/src/blink_impl/blink_controller.rs b/extensions/warp-blink-wrtc/src/blink_impl/blink_controller.rs index 81acf7780..bc9c08a35 100644 --- a/extensions/warp-blink-wrtc/src/blink_impl/blink_controller.rs +++ b/extensions/warp-blink-wrtc/src/blink_impl/blink_controller.rs @@ -362,8 +362,7 @@ async fn run( let topic = ipfs_routes::call_signal_route(&call_id); let signal = CallSignal::Announce; if let Err(e) = - gossipsub_sender - .send_signal_aes(call_info.group_key(), signal, topic) + gossipsub_sender.announce(call_info.group_key(), signal, topic) { log::error!("failed to send announce signal: {e}"); } @@ -421,14 +420,13 @@ async fn run( webrtc_codec).await; match r { Ok(_) => { - log::debug!("answering call. sending join signal"); + log::debug!("answering call"); gossipsub_listener.subscribe_call(call_id, call_info.group_key()); gossipsub_listener.subscribe_webrtc(call_id, own_id.clone()); let topic = ipfs_routes::call_signal_route(&call_id); let signal = CallSignal::Announce; if let Err(e) = - gossipsub_sender - .send_signal_aes(call_info.group_key(), signal, topic) + gossipsub_sender.announce(call_info.group_key(), signal, topic) { let _ = rsp.send(Err(Error::FailedToSendSignal(e.to_string()))); } else {