Revert "Factor out connection, peer management, and packet handling i…

…nto `VideoCallClient` (#137)" (#148)

This reverts commit bb27fb4.

yew-ui/src/components/host.rs

@@ -1,11 +1,13 @@
-use crate::model::client::VideoCallClient;
 use gloo_timers::callback::Timeout;
 use log::debug;
+use types::protos::packet_wrapper::PacketWrapper;
 
 use std::fmt::Debug;
+use std::sync::Arc;
 use yew::prelude::*;
 
 use crate::components::device_selector::DeviceSelector;
+use crate::crypto::aes::Aes128State;
 use crate::model::encode::CameraEncoder;
 use crate::model::encode::MicrophoneEncoder;
 use crate::model::encode::ScreenEncoder;
@@ -38,25 +40,31 @@ pub struct MeetingProps {
     #[prop_or_default]
     pub id: String,
 
-    pub client: VideoCallClient,
+    #[prop_or_default]
+    pub on_packet: Callback<PacketWrapper>,
+
+    #[prop_or_default]
+    pub email: String,
 
     pub share_screen: bool,
 
     pub mic_enabled: bool,
 
     pub video_enabled: bool,
+
+    pub aes: Arc<Aes128State>,
 }
 
 impl Component for Host {
     type Message = Msg;
     type Properties = MeetingProps;
 
     fn create(ctx: &Context<Self>) -> Self {
-        let client = &ctx.props().client;
+        let aes = ctx.props().aes.clone();
         Self {
-            camera: CameraEncoder::new(client.clone(), VIDEO_ELEMENT_ID),
-            microphone: MicrophoneEncoder::new(client.clone()),
-            screen: ScreenEncoder::new(client.clone()),
+            camera: CameraEncoder::new(aes.clone()),
+            microphone: MicrophoneEncoder::new(aes.clone()),
+            screen: ScreenEncoder::new(aes),
             share_screen: ctx.props().share_screen,
             mic_enabled: ctx.props().mic_enabled,
             video_enabled: ctx.props().video_enabled,
@@ -99,7 +107,10 @@ impl Component for Host {
     fn update(&mut self, ctx: &Context<Self>, msg: Self::Message) -> bool {
         match msg {
             Msg::EnableScreenShare => {
-                self.screen.start();
+                let on_frame = ctx.props().on_packet.clone();
+                let email = ctx.props().email.clone();
+                self.screen
+                    .start(email, move |packet: PacketWrapper| on_frame.emit(packet));
                 true
             }
             Msg::DisableScreenShare => {
@@ -111,7 +122,10 @@ impl Component for Host {
                 if !should_enable {
                     return true;
                 }
-                self.microphone.start();
+                let on_audio = ctx.props().on_packet.clone();
+                let email = ctx.props().email.clone();
+                self.microphone
+                    .start(email, move |packet: PacketWrapper| on_audio.emit(packet));
                 true
             }
             Msg::DisableMicrophone => {
@@ -123,7 +137,13 @@ impl Component for Host {
                     return true;
                 }
 
-                self.camera.start();
+                let on_packet = ctx.props().on_packet.clone();
+                let email = ctx.props().email.clone();
+                self.camera.start(
+                    email,
+                    move |packet: PacketWrapper| on_packet.emit(packet),
+                    VIDEO_ELEMENT_ID,
+                );
                 true
             }
             Msg::DisableVideo => {