Merge pull request #5 from derenv/subprocess_communicate

Subprocess communicate

Author: derenv

src/main.rs

@@ -83,8 +83,6 @@ fn build_ui(app: &Application) {
         .build();
     // Connect to "clicked" signal of `button`
     button2.connect_clicked(move |_| {
-        println!("Trying to open settings!"); //DEBUG
-
         // Ideally we should grab if nvidia-settings 'failed' somehow or exited normally
         match subprocess::exec_communicate(
             &[
@@ -93,14 +91,38 @@ fn build_ui(app: &Application) {
                 OsStr::new("GpuUUID"),
                 OsStr::new("-t"),
             ],
-            None,
             None::<&gio::Cancellable>,
         ) {
-            Ok(_x) => {
-                println!("........yay"); //DEBUG
+            Ok(return_val) => {
+                match return_val {
+                    (None, None) => println!("no stdout or stderr, something went really wrong..."),
+                    (None, Some(stderr_buffer)) => {
+                        match std::str::from_utf8(&stderr_buffer) {
+                            Ok(stderr_buffer_contents) => println!("Process failed with error: {}", stderr_buffer_contents),
+                            Err(err) => panic!("{}", err),
+                        }
+                    },
+                    (Some(stdout_buffer), None) => {
+                        match std::str::from_utf8(&stdout_buffer) {
+                            Ok(stdout_buffer_contents) => println!("Process suceeded, returning: {}", stdout_buffer_contents),
+                            Err(err) => panic!("{}", err),
+                        }
+                    },
+                    (Some(stdout_buffer), Some(stderr_buffer)) => {
+                        match std::str::from_utf8(&stdout_buffer) {
+                            Ok(stdout_buffer_contents)=> {
+                                match std::str::from_utf8(&stderr_buffer) {
+                                    Ok(stderr_buffer_contents) => println!("Process suceeded, returning: {} but with error: {}", stdout_buffer_contents, stderr_buffer_contents),
+                                    Err(err) => panic!("{}", err),
+                                }
+                            },
+                            Err(err) => panic!("{}", err),
+                        }
+                    },
+                }
             }
             Err(_y) => {
-                println!("........fak"); //DEBUG
+                println!("something went wrong!"); //DEBUG
             }
         };
     });
@@ -132,8 +154,8 @@ fn build_ui(app: &Application) {
     window.set_show_menubar(true);
 
     // Add children to window
-    window.set_child(Some(&button1));
-    //window.set_child(Some(&button2));
+    //window.set_child(Some(&button1));
+    window.set_child(Some(&button2));
 
     // Present window
     window.show();

src/processor/mod.rs

@@ -54,6 +54,7 @@ impl Processor {
     }
 
     pub fn get_name(self) -> String {
-        self.name
+        todo!()
+        //self.name
     }
 }

src/subprocess/mod.rs

@@ -18,8 +18,8 @@
  * https://blog.logrocket.com/a-practical-guide-to-async-in-rust/
  */
 
-// Imports
 use gtk::glib::Bytes;
+// Imports
 use gtk::prelude::*;
 use gtk::{gio, glib};
 use std::ffi::OsStr;
@@ -82,20 +82,23 @@ pub fn exec_check(
  */
 pub fn exec_communicate(
     argv: &[&OsStr],
-    _input: Option<&str>,
     cancellable: Option<&impl IsA<gio::Cancellable>>,
 ) -> Result<(Option<Bytes>, Option<Bytes>), glib::Error> {
     // Create subprocess
-    println!("..creating subprocess"); //DEBUG
-    match gio::Subprocess::newv(argv, gio::SubprocessFlags::NONE) {
+    match gio::Subprocess::newv(argv, gio::SubprocessFlags::STDOUT_PIPE) {
         Err(err) => Err(err),
         Ok(proc) => {
-            println!("..Subprocess successfully created!"); //DEBUG
-
             // Run subprocess
             match proc.communicate(None, cancellable) {
                 Err(err) => Err(err),
-                Ok(out) => Ok(out),
+                Ok(buffers) => match buffers {
+                    (None, None) => Ok((None, None)),
+                    (None, Some(stderr_buffer)) => Ok((None, Some(stderr_buffer))),
+                    (Some(stdout_buffer), None) => Ok((Some(stdout_buffer), None)),
+                    (Some(stdout_buffer), Some(stderr_buffer)) => {
+                        Ok((Some(stdout_buffer), Some(stderr_buffer)))
+                    }
+                },
             }
         }
     }