custom: Add WebRTCTest

Signed-off-by: Patrick José Pereira <[email protected]>

src/custom/mod.rs

@@ -4,18 +4,21 @@ use crate::cli;
 use crate::video_stream::types::VideoAndStreamInformation;
 
 mod bluerov;
+mod test;
 
 #[derive(ValueEnum, PartialEq, Debug, Clone)]
 #[clap(rename_all = "verbatim")]
 pub enum CustomEnvironment {
     BlueROVUDP,
     BlueROVRTSP,
+    WebRTCTest,
 }
 
 pub fn create_default_streams() -> Vec<VideoAndStreamInformation> {
     match cli::manager::default_settings() {
         Some(CustomEnvironment::BlueROVUDP) => bluerov::udp(),
         Some(CustomEnvironment::BlueROVRTSP) => bluerov::rtsp(),
+        Some(CustomEnvironment::WebRTCTest) => test::take_webrtc_stream(),
         _ => vec![],
     }
 }

src/custom/test.rs

@@ -0,0 +1,29 @@
+use url::Url;
+
+use crate::stream::types::*;
+use crate::video::{self, types::*, video_source_gst::VideoSourceGstType};
+use crate::video_stream::types::VideoAndStreamInformation;
+
+pub fn take_webrtc_stream() -> Vec<VideoAndStreamInformation> {
+    let size = STANDARD_SIZES.last().unwrap();
+    vec![VideoAndStreamInformation {
+        name: format!("WebRTC fake stream for thread leak"),
+        stream_information: StreamInformation {
+            endpoints: vec![Url::parse("udp://0.0.0.0:8554/video_0").unwrap()],
+            configuration: CaptureConfiguration::Video(VideoCaptureConfiguration {
+                encode: VideoEncodeType::H264,
+                height: size.1,
+                width: size.0,
+                frame_interval: FrameInterval {
+                    denominator: 10,
+                    numerator: 1,
+                },
+            }),
+            extended_configuration: None,
+        },
+        video_source: VideoSourceType::Gst(video::video_source_gst::VideoSourceGst {
+            name: "Fake".into(),
+            source: VideoSourceGstType::Fake("ball".into()),
+        }),
+    }]
+}