From f561cc7df17a869caf6f1e6a77c3a29a9ddaf743 Mon Sep 17 00:00:00 2001
From: Gregor Reitzenstein <me@dequbed.space>
Date: Fri, 20 Nov 2020 15:38:11 +0100
Subject: [PATCH] Print stuff

---
 src/app.rs             | 14 +++++++-------
 src/schema/machine.rs  | 18 ++++++++++++------
 src/schema/machines.rs | 39 ++++++++++++++++++++++++++++++++++++++-
 3 files changed, 57 insertions(+), 14 deletions(-)

diff --git a/src/app.rs b/src/app.rs
index 7b24499..083d6ba 100644
--- a/src/app.rs
+++ b/src/app.rs
@@ -101,14 +101,14 @@ impl<'a, S: Unpin> Sute<'a, S> {
                             if let Some(mut api) = self.session.as_ref().map(|s| s.bootstrap.clone()) {
                                 let log = self.log.clone();
 
-                                let f = api.machines().map(|mut machines| {
-                                    machines.get_machine(uuid).map(move |res| {
-                                        res.map(|m| {
-                                            m.get_info().map(move |info| {
-                                                info!(log, "Yay, stuff! {:?}", info);
-                                            })
+                                let machines = api.machines();
+                                let machine = machines.then(|mut machines| {
+                                    machines.get_machine(uuid)
+                                });
+                                let f = machine.then(move |res| {
+                                        res.as_ref().unwrap().get_info().map(move |info| {
+                                            info!(log, "Yay, stuff! {:?}", info);
                                         })
-                                    })
                                 });
                                 let old_f = self.future.replace(Box::pin(f.map(|_| ())));
                                 if !old_f.is_none() {
diff --git a/src/schema/machine.rs b/src/schema/machine.rs
index 02c3382..2b06885 100644
--- a/src/schema/machine.rs
+++ b/src/schema/machine.rs
@@ -1,30 +1,36 @@
 use std::fmt;
 use std::any::Any;
 use std::future::Future;
+use futures::FutureExt;
 
 use super::api_capnp::machine::read::Client;
 
 pub struct Machine {
-    read: Option<Client>,
+    read: Client,
 }
 impl fmt::Debug for Machine {
     fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
         let mut b = f.debug_struct("Machine");
-        if let Some(r) = self.read.as_ref() {
-            b.field("read", &r.type_id());
-        }
+        b.field("read", &self.read.type_id());
         b.finish()
     }
 }
 
 impl Machine {
-    pub fn new(read: Option<Client>) -> Self {
+    pub fn new(read: Client) -> Self {
         Machine {
             read,
         }
     }
 
     pub fn get_info(&self) -> impl Future<Output=Option<String>> {
-        futures::future::ready(None)
+        let req = self.read.info_request().send().promise;
+        req.map(|res| {
+            res.unwrap().get().unwrap().get_minfo().ok().map(|minfo| {
+                // TODO state
+                format!("Name: {:?}\n Description: {:?}\nState: ",
+                    minfo.get_name(), minfo.get_description())
+            })
+        })
     }
 }
diff --git a/src/schema/machines.rs b/src/schema/machines.rs
index b8f95eb..e88fad0 100644
--- a/src/schema/machines.rs
+++ b/src/schema/machines.rs
@@ -1,11 +1,15 @@
+use std::str::FromStr;
 use std::fmt;
 use std::any::Any;
 use std::future::Future;
+use futures::FutureExt;
 
 use super::api_capnp::machines::Client;
 
 use super::machine::Machine;
 
+use uuid::Uuid;
+
 pub struct Machines {
     inner: Client,
 }
@@ -23,6 +27,39 @@ impl Machines {
     }
 
     pub fn get_machine(&mut self, uuid: String) -> impl Future<Output=Option<Machine>> {
-        futures::future::ready(None)
+        let mut req = self.inner.get_machine_request();
+        let param_builder = req.get();
+        let uuid_builder = param_builder.init_uuid();
+        api_from_uuid(Uuid::from_str(&uuid).unwrap(), uuid_builder);
+
+        let prom = req.send().promise;
+
+        // TODO: When's that an Err?
+        prom.map(|res| {
+            // TODO: When's that an Err?
+            let tmp = res.unwrap();
+            let moretmp = tmp.get().unwrap();
+            if let Ok(m) = moretmp.get_machine() {
+                match m.get_read() {
+                    Ok(m) => return Some(Machine::new(m)),
+                    Err(e) => println!("{}", e),
+                }
+            }
+            None
+        })
     }
 }
+
+pub fn uuid_from_api(uuid: crate::schema::api_capnp::u_u_i_d::Reader) -> Uuid {
+    let uuid0 = uuid.get_uuid0() as u128;
+    let uuid1 = uuid.get_uuid1() as u128;
+    let num: u128 = (uuid0 << 64) + uuid1;
+    Uuid::from_u128(num)
+}
+pub fn api_from_uuid(uuid: Uuid, mut wr: crate::schema::api_capnp::u_u_i_d::Builder) {
+    let num = uuid.as_u128();
+    let uuid0 = num as u64;
+    let uuid1 = (num >> 64) as u64;
+    wr.set_uuid0(uuid0);
+    wr.set_uuid1(uuid1);
+}