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 # contains x264enc
-          # gst_all_1.gst-plugins-rs #contains whipclientsink
+          gst_all_1.gst-plugins-ugly
+          gst_all_1.gst-plugins-rs
           mediamtx
         ];
         cargoHash = nixpkgs.lib.fakeHash;

rtsp-simple-server.yml

@@ -1,9 +1,3 @@
-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

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

src/main.rs

@@ -2,6 +2,7 @@ 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};
 
 
@@ -21,7 +22,6 @@ fn main() -> Result<(), Error> {
     })?;
 
     gstreamer::init()?;
-    gstrswebrtc::plugin_register_static()?;
 
     let pipeline = Pipeline::with_name("rstp-pipeline");
 
@@ -36,12 +36,13 @@ fn main() -> Result<(), Error> {
         .name("whip-sink_123059")
         .build()?;
 
-    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"),
-        );
+    // 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"),
+        //);
     }
 
     pipeline.add_many([&source, &convert, &whipsink]).unwrap();