use gst::prelude::*; use gtk::prelude::*; use gtk::{gdk, gio, glib}; use std::cell::RefCell; fn create_ui(app: >k::Application) { let window = gtk::ApplicationWindow::new(app); window.set_default_size(640, 480); let vbox = gtk::Box::new(gtk::Orientation::Vertical, 0); let picture = gtk::Picture::new(); let label = gtk::Label::new(Some("Position: 00:00:00")); let pipeline = gst::Pipeline::new(None); let overlay = gst::ElementFactory::make("clockoverlay") .property("font-desc", "Monospace 42") .build() .unwrap(); let gtksink = gst::ElementFactory::make("gtk4paintablesink") .build() .unwrap(); // Need to set state to Ready to get a GL context gtksink.set_state(gst::State::Ready).unwrap(); let paintable = gtksink.property::("paintable"); // TODO: future plans to provide a bin-like element that works with less setup let (src, sink) = if paintable .property::>("gl-context") .is_some() { let src = gst::ElementFactory::make("gltestsrc").build().unwrap(); let sink = gst::ElementFactory::make("glsinkbin") .property("sink", >ksink) .build() .unwrap(); (src, sink) } else { let src = gst::ElementFactory::make("videotestsrc").build().unwrap(); let sink = gst::Bin::default(); let convert = gst::ElementFactory::make("videoconvert").build().unwrap(); sink.add(&convert).unwrap(); sink.add(>ksink).unwrap(); convert.link(>ksink).unwrap(); sink.add_pad( &gst::GhostPad::with_target(Some("sink"), &convert.static_pad("sink").unwrap()) .unwrap(), ) .unwrap(); (src, sink.upcast()) }; pipeline.add_many(&[&src, &overlay, &sink]).unwrap(); let caps = gst_video::VideoCapsBuilder::new() .width(640) .height(480) .any_features() .build(); src.link_filtered(&overlay, &caps).unwrap(); overlay.link(&sink).unwrap(); picture.set_paintable(Some(&paintable)); vbox.append(&picture); vbox.append(&label); window.set_child(Some(&vbox)); window.show(); app.add_window(&window); let pipeline_weak = pipeline.downgrade(); let timeout_id = glib::timeout_add_local(std::time::Duration::from_millis(500), move || { let pipeline = match pipeline_weak.upgrade() { Some(pipeline) => pipeline, None => return glib::Continue(true), }; let position = pipeline.query_position::(); label.set_text(&format!("Position: {:.0}", position.display())); glib::Continue(true) }); let bus = pipeline.bus().unwrap(); pipeline .set_state(gst::State::Playing) .expect("Unable to set the pipeline to the `Playing` state"); let app_weak = app.downgrade(); bus.add_watch_local(move |_, msg| { use gst::MessageView; let app = match app_weak.upgrade() { Some(app) => app, None => return glib::Continue(false), }; match msg.view() { MessageView::Eos(..) => app.quit(), MessageView::Error(err) => { println!( "Error from {:?}: {} ({:?})", err.src().map(|s| s.path_string()), err.error(), err.debug() ); app.quit(); } _ => (), }; glib::Continue(true) }) .expect("Failed to add bus watch"); let timeout_id = RefCell::new(Some(timeout_id)); let pipeline = RefCell::new(Some(pipeline)); app.connect_shutdown(move |_| { window.close(); if let Some(pipeline) = pipeline.borrow_mut().take() { pipeline .set_state(gst::State::Null) .expect("Unable to set the pipeline to the `Null` state"); pipeline.bus().unwrap().remove_watch().unwrap(); } if let Some(timeout_id) = timeout_id.borrow_mut().take() { timeout_id.remove(); } }); } fn main() { gst::init().unwrap(); gtk::init().unwrap(); gstgtk4::plugin_register_static().expect("Failed to register gstgtk4 plugin"); let app = gtk::Application::new(None, gio::ApplicationFlags::FLAGS_NONE); app.connect_activate(create_ui); app.run(); unsafe { gst::deinit(); } }