added mediamtx example files

flake.nix

@@ -39,10 +39,10 @@ Some utility commands:
           openssl
           gst_all_1.gstreamer
           gst_all_1.gst-plugins-base
-          gst_all_1.gst-plugins-good
+          # gst_all_1.gst-plugins-good
           gst_all_1.gst-plugins-bad # contains gst-webrtc 
-          gst_all_1.gst-plugins-ugly
-          gst_all_1.gst-plugins-rs
+          gst_all_1.gst-plugins-ugly # contains x264enc
+          # gst_all_1.gst-plugins-rs #contains whipclientsink
           mediamtx
         ];
         cargoHash = nixpkgs.lib.fakeHash;

rtsp-simple-server.yml

@@ -1,3 +1,9 @@
+webrtcAdditionalHosts: [localhost, 0.0.0.0, 127.0.0.1, 10.0.0.114]
+
+logLevel: debug
+webrtcLocalTCPAddress: :8188
+api: yes
+
 paths:
   mystream:
     source: publisher

rtsp-simple-server.yml.old

@@ -0,0 +1,13 @@
+
+api: no
+apiAddress: :9997
+apiEncryption: no
+
+paths:
+  mystream:
+    source: publisher
+
+webrtc: yes
+webrtcAddress: :8889
+webrtcLocalUDPAddress: :8189
+webrtcEncryption: no

src/main.rs

@@ -2,7 +2,6 @@ use std::sync::{atomic::AtomicBool, Arc};
 
 use anyhow::Error;
 use gstreamer::{prelude::*, Element, ElementFactory, Pipeline, State};
-use tracing::info;
 use gstrswebrtc::{signaller::Signallable, webrtcsink::WhipWebRTCSink};
 
 
@@ -22,6 +21,7 @@ fn main() -> Result<(), Error> {
     })?;
 
     gstreamer::init()?;
+    gstrswebrtc::plugin_register_static()?;
 
     let pipeline = Pipeline::with_name("rstp-pipeline");
 
@@ -36,13 +36,12 @@ fn main() -> Result<(), Error> {
         .name("whip-sink_123059")
         .build()?;
 
-    // THIS IS THE LINE CAUSING THE ERROR
-    if let Some(whipsink) = whipsink.dynamic_cast_ref::<WhipWebRTCSink>() {
-        //let signaller = whipsink.property::<Signallable>("signaller");
-        //signaller.set_property_from_str(
-        //    "whip-endpoint",
-        //    &format!("http://localhost:{}/whip_sink/{}", 8889, "mystream"),
-        //);
+    if let Some(whipsink) = whipsink.dynamic_cast_ref::<gstrswebrtc::webrtcsink::WhipWebRTCSink>() {
+        let signaller = whipsink.property::<Signallable>("signaller");
+        signaller.set_property_from_str(
+           "whip-endpoint",
+           &format!("http://localhost:{}/{}/whip", 8889, "mystream"),
+        );
     }
 
     pipeline.add_many([&source, &convert, &whipsink]).unwrap();