Skip to content

Commit

Permalink
fix fmt
Browse files Browse the repository at this point in the history
  • Loading branch information
sdwoodbury committed Nov 3, 2023
1 parent 9d88649 commit b822698
Show file tree
Hide file tree
Showing 3 changed files with 14 additions and 47 deletions.
26 changes: 5 additions & 21 deletions extensions/warp-blink-wrtc/src/blink_impl/call_initiation.rs
Original file line number Diff line number Diff line change
@@ -1,39 +1,23 @@





use std::{
collections::{HashMap, HashSet},
sync::Arc,
};




use futures::StreamExt;

use rust_ipfs::{SubscriptionStream};
use rust_ipfs::SubscriptionStream;

use tokio::{
sync::{
broadcast::{Sender},
RwLock,
},
};
use tokio::sync::{broadcast::Sender, RwLock};
use uuid::Uuid;
use warp::{
blink::{BlinkEventKind},
blink::BlinkEventKind,
crypto::{did_key::Generate, DID},
error::Error,
};

use crate::{
signaling::{InitiationSignal},
store::{
decode_gossipsub_msg_ecdh,
PeerIdExt,
},
signaling::InitiationSignal,
store::{decode_gossipsub_msg_ecdh, PeerIdExt},
};

use super::data::PendingCall;
Expand Down
14 changes: 3 additions & 11 deletions extensions/warp-blink-wrtc/src/blink_impl/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -19,13 +19,7 @@ use host_media::{
},
mp4_logger::Mp4LoggerConfig,
};
use std::{
any::Any,
collections::{HashMap},
str::FromStr,
sync::Arc,
time::Duration,
};
use std::{any::Any, collections::HashMap, str::FromStr, sync::Arc, time::Duration};
use webrtc::rtp_transceiver::rtp_codec::RTCRtpCodecCapability;

use anyhow::{bail, Context};
Expand Down Expand Up @@ -54,10 +48,8 @@ use warp::{
use crate::{
host_media::audio::AudioSampleRate,
signaling::{ipfs_routes, CallSignal, InitiationSignal},
simple_webrtc::events::{WebRtcEventStream},
store::{
send_signal_aes, send_signal_ecdh,
},
simple_webrtc::events::WebRtcEventStream,
store::{send_signal_aes, send_signal_ecdh},
};

// implements Blink
Expand Down
21 changes: 6 additions & 15 deletions extensions/warp-blink-wrtc/src/blink_impl/webrtc_handler.rs
Original file line number Diff line number Diff line change
Expand Up @@ -5,27 +5,18 @@ use crate::simple_webrtc;
use futures::StreamExt;
use rust_ipfs::{Ipfs, SubscriptionStream};
use std::sync::Arc;
use tokio::{
sync::{
broadcast::{self, Sender},
RwLock,
},
use tokio::sync::{
broadcast::{self, Sender},
RwLock,
};

use warp::{
blink::{BlinkEventKind},
crypto::{DID},
error::Error,
};
use warp::{blink::BlinkEventKind, crypto::DID, error::Error};

use crate::{
host_media::audio::{AudioHardwareConfig},
host_media::audio::AudioHardwareConfig,
signaling::{ipfs_routes, CallSignal, PeerSignal},
simple_webrtc::events::{EmittedEvents, WebRtcEventStream},
store::{
decode_gossipsub_msg_aes, decode_gossipsub_msg_ecdh, send_signal_ecdh,
PeerIdExt,
},
store::{decode_gossipsub_msg_aes, decode_gossipsub_msg_ecdh, send_signal_ecdh, PeerIdExt},
};

pub struct WebRtcHandlerParams {
Expand Down

0 comments on commit b822698

Please sign in to comment.