Skip to content

Commit

Permalink
fix signalling - use announce
Browse files Browse the repository at this point in the history
  • Loading branch information
sdwoodbury committed Nov 9, 2023
1 parent 7c277cc commit 451397c
Showing 1 changed file with 3 additions and 5 deletions.
8 changes: 3 additions & 5 deletions extensions/warp-blink-wrtc/src/blink_impl/blink_controller.rs
Original file line number Diff line number Diff line change
Expand Up @@ -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}");
}
Expand Down Expand Up @@ -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 {
Expand Down

0 comments on commit 451397c

Please sign in to comment.