1 files changed, 21 insertions, 18 deletions

diff --git a/src/client/refinery.rs b/src/client/refinery.rs
index 013172d..caceda7 100644
--- a/src/client/refinery.rs
+++ b/src/client/refinery.rs
@@ -1,16 +1,16 @@
-extern crate termion;
 extern crate serde_json;
+extern crate termion;
 
-use std::net::TcpStream;
 use self::termion::async_stdin;
-use std::io::{BufRead, BufReader};
-use std::io::{stdout, Read, Write};
 use self::termion::raw::IntoRawMode;
+use std::io::{stdout, Read, Write};
+use std::io::{BufRead, BufReader};
+use std::net::TcpStream;
 
-use server::refinery::RefineryData;
-use modules::refinery::RefineryStatus;
+use crate::modules::refinery::RefineryStatus;
+use crate::server::refinery::RefineryData;
 
-pub fn client_refinery(mut stream : TcpStream, mut buff_r : BufReader<TcpStream>) {
+pub fn client_refinery(mut stream: TcpStream, mut buff_r: BufReader<TcpStream>) {
     let stdout = stdout();
     let mut stdout = stdout.lock().into_raw_mode().unwrap();
     let mut stdin = async_stdin().bytes();
@@ -18,21 +18,24 @@ pub fn client_refinery(mut stream : TcpStream, mut buff_r : BufReader<TcpStream>
     loop {
         let mut recv = String::new();
         buff_r.read_line(&mut recv).unwrap();
-        let data : RefineryData = serde_json::from_str(&recv.replace("\n", "")).unwrap();
+        let data: RefineryData = serde_json::from_str(&recv.replace("\n", "")).unwrap();
 
         write!(stdout, "{}", termion::clear::All).unwrap();
 
-        let clear = termion::cursor::Goto(1,1);
-
-        match data.has_minerals {
-            true => match data.status {
-                    RefineryStatus::None => write!(stdout, "{}Press R to begin refining.", clear).unwrap(),
-                    _ => write!(stdout, "{}Press R to stop refining.", clear).unwrap(),
-            },
-            false => write!(stdout, "{}You have no refinable minerals.", clear).unwrap(),
+        let clear = termion::cursor::Goto(1, 1);
+
+        if data.has_minerals {
+            match data.status {
+                RefineryStatus::None => {
+                    write!(stdout, "{}Press R to begin refining.", clear).unwrap()
+                }
+                _ => write!(stdout, "{}Press R to stop refining.", clear).unwrap(),
+            };
+        } else {
+            write!(stdout, "{}You have no refinable minerals.", clear).unwrap();
         }
 
-        if let Some(c) =  stdin.next() {
+        if let Some(c) = stdin.next() {
             let c = c.unwrap();
             let mut send = String::new();
             send.push(c as char);
@@ -40,7 +43,7 @@ pub fn client_refinery(mut stream : TcpStream, mut buff_r : BufReader<TcpStream>
                 break;
             }
             send.push_str("\n");
-            stream.write(send.as_bytes()).unwrap();
+            stream.write_all(send.as_bytes()).unwrap();
         }
 
         stdout.flush().unwrap();