Apply rustfmt style globally

This applies the current rustfmt style across all source code. Signed-off-by: Otavio Salvador <otavio@ossystems.com.br>
balena-os · Oct 30, 2018 · df8fcad · df8fcad
1 parent 40dde2c
commit df8fcad
Show file tree

Hide file tree

Showing 6 changed files with 72 additions and 57 deletions.
diff --git a/src/config.rs b/src/config.rs
@@ -1,10 +1,10 @@
 use clap::{App, Arg};
 
 use std::env;
+use std::ffi::OsStr;
 use std::net::Ipv4Addr;
-use std::str::FromStr;
 use std::path::PathBuf;
-use std::ffi::OsStr;
+use std::str::FromStr;
 
 const DEFAULT_GATEWAY: &str = "192.168.42.1";
 const DEFAULT_DHCP_RANGE: &str = "192.168.42.2,192.168.42.254";
@@ -129,7 +129,8 @@ pub fn get_config() -> Config {
     let gateway = Ipv4Addr::from_str(&matches.value_of("portal-gateway").map_or_else(
         || env::var("PORTAL_GATEWAY").unwrap_or_else(|_| DEFAULT_GATEWAY.to_string()),
         String::from,
-    )).expect("Cannot parse gateway address");
+    ))
+    .expect("Cannot parse gateway address");
 
     let dhcp_range = matches.value_of("portal-dhcp-range").map_or_else(
         || env::var("PORTAL_DHCP_RANGE").unwrap_or_else(|_| DEFAULT_DHCP_RANGE.to_string()),
@@ -151,7 +152,8 @@ pub fn get_config() -> Config {
     let activity_timeout = u64::from_str(&matches.value_of("activity-timeout").map_or_else(
         || env::var("ACTIVITY_TIMEOUT").unwrap_or_else(|_| DEFAULT_ACTIVITY_TIMEOUT.to_string()),
         String::from,
-    )).expect("Cannot parse activity timeout");
+    ))
+    .expect("Cannot parse activity timeout");
 
     let ui_directory = get_ui_directory(matches.value_of("ui-directory"));
 

diff --git a/src/dnsmasq.rs b/src/dnsmasq.rs
@@ -2,8 +2,8 @@ use std::process::{Child, Command};
 
 use network_manager::Device;
 
-use errors::*;
 use config::Config;
+use errors::*;
 
 pub fn start_dnsmasq(config: &Config, device: &Device) -> Result<Child> {
     let args = [

diff --git a/src/logger.rs b/src/logger.rs
@@ -1,6 +1,6 @@
-use std::env;
-use log::{LogLevel, LogLevelFilter, LogRecord};
 use env_logger::LogBuilder;
+use log::{LogLevel, LogLevelFilter, LogRecord};
+use std::env;
 
 pub fn init() {
     let mut builder = LogBuilder::new();

diff --git a/src/main.rs b/src/main.rs
@@ -24,25 +24,25 @@ extern crate router;
 extern crate serde_json;
 extern crate staticfile;
 
-mod errors;
 mod config;
-mod network;
-mod server;
 mod dnsmasq;
-mod logger;
+mod errors;
 mod exit;
+mod logger;
+mod network;
 mod privileges;
+mod server;
 
-use std::path;
-use std::thread;
-use std::sync::mpsc::channel;
 use std::io::Write;
+use std::path;
 use std::process;
+use std::sync::mpsc::channel;
+use std::thread;
 
-use errors::*;
 use config::get_config;
-use network::{init_networking, process_network_commands};
+use errors::*;
 use exit::block_exit_signals;
+use network::{init_networking, process_network_commands};
 use privileges::require_root;
 
 fn main() {
@@ -78,8 +78,10 @@ fn run() -> Result<()> {
     });
 
     match exit_rx.recv() {
-        Ok(result) => if let Err(reason) = result {
-            return Err(reason);
+        Ok(result) => {
+            if let Err(reason) = result {
+                return Err(reason);
+            }
         },
         Err(e) => {
             return Err(e.into());

diff --git a/src/network.rs b/src/network.rs
@@ -1,17 +1,19 @@
-use std::thread;
-use std::process;
-use std::time::Duration;
-use std::sync::mpsc::{channel, Receiver, Sender};
 use std::error::Error;
 use std::net::Ipv4Addr;
+use std::process;
+use std::sync::mpsc::{channel, Receiver, Sender};
+use std::thread;
+use std::time::Duration;
 
-use network_manager::{AccessPoint, AccessPointCredentials, Connection, ConnectionState,
-                      Connectivity, Device, DeviceType, NetworkManager, Security, ServiceState};
+use network_manager::{
+    AccessPoint, AccessPointCredentials, Connection, ConnectionState, Connectivity, Device,
+    DeviceType, NetworkManager, Security, ServiceState,
+};
 
-use errors::*;
-use exit::{exit, trap_exit_signals, ExitResult};
 use config::Config;
 use dnsmasq::start_dnsmasq;
+use errors::*;
+use exit::{exit, trap_exit_signals, ExitResult};
 use server::start_server;
 
 pub enum NetworkCommand {
@@ -495,7 +497,8 @@ pub fn start_network_manager_service() -> Result<()> {
     };
 
     if state != ServiceState::Active {
-        let state = NetworkManager::start_service(15).chain_err(|| ErrorKind::StartNetworkManager)?;
+        let state =
+            NetworkManager::start_service(15).chain_err(|| ErrorKind::StartNetworkManager)?;
         if state != ServiceState::Active {
             bail!(ErrorKind::StartActiveNetworkManager);
         } else {

diff --git a/src/server.rs b/src/server.rs
@@ -1,24 +1,25 @@
-use std::sync::mpsc::{Receiver, Sender};
+use std::error::Error as StdError;
 use std::fmt;
 use std::net::Ipv4Addr;
-use std::error::Error as StdError;
+use std::sync::mpsc::{Receiver, Sender};
 
-use serde_json;
-use path::PathBuf;
-use iron::prelude::*;
-use iron::{headers, status, typemap, AfterMiddleware, Iron, IronError, IronResult, Request,
-           Response, Url};
 use iron::modifiers::Redirect;
+use iron::prelude::*;
+use iron::{
+    headers, status, typemap, AfterMiddleware, Iron, IronError, IronResult, Request, Response, Url,
+};
 use iron_cors::CorsMiddleware;
-use router::Router;
-use staticfile::Static;
 use mount::Mount;
-use persistent::Write;
 use params::{FromValue, Params};
+use path::PathBuf;
+use persistent::Write;
+use router::Router;
+use serde_json;
+use staticfile::Static;
 
 use errors::*;
-use network::{NetworkCommand, NetworkCommandResponse};
 use exit::{exit, ExitResult};
+use network::{NetworkCommand, NetworkCommandResponse};
 
 struct RequestSharedState {
     gateway: Ipv4Addr,
@@ -47,47 +48,54 @@ impl StdError for StringError {
 }
 
 macro_rules! get_request_ref {
-    ($req:ident, $ty:ty, $err:expr) => (
+    ($req:ident, $ty:ty, $err:expr) => {
         match $req.get_ref::<$ty>() {
             Ok(val) => val,
             Err(err) => {
                 error!($err);
                 return Err(IronError::new(err, status::InternalServerError));
-            }
+            },
         }
-    )
+    };
 }
 
 macro_rules! get_param {
-    ($params:ident, $param:expr, $ty:ty) => (
+    ($params:ident, $param:expr, $ty:ty) => {
         match $params.get($param) {
-            Some(value) => {
-                match <$ty as FromValue>::from_value(value) {
-                    Some(converted) => converted,
-                    None => {
-                        let err = format!("Unexpected type for '{}'", $param);
-                        error!("{}", err);
-                        return Err(IronError::new(StringError(err), status::InternalServerError));
-                    }
-                }
+            Some(value) => match <$ty as FromValue>::from_value(value) {
+                Some(converted) => converted,
+                None => {
+                    let err = format!("Unexpected type for '{}'", $param);
+                    error!("{}", err);
+                    return Err(IronError::new(
+                        StringError(err),
+                        status::InternalServerError,
+                    ));
+                },
             },
             None => {
                 let err = format!("'{}' not found in request params: {:?}", $param, $params);
                 error!("{}", err);
-                return Err(IronError::new(StringError(err), status::InternalServerError));
-            }
+                return Err(IronError::new(
+                    StringError(err),
+                    status::InternalServerError,
+                ));
+            },
         }
-    )
+    };
 }
 
 macro_rules! get_request_state {
-    ($req:ident) => (
+    ($req:ident) => {
         get_request_ref!(
             $req,
             Write<RequestSharedState>,
             "Getting reference to request shared state failed"
-        ).as_ref().lock().unwrap()
-    )
+        )
+        .as_ref()
+        .lock()
+        .unwrap()
+    };
 }
 
 fn exit_with_error<E>(state: &RequestSharedState, e: E, e_kind: ErrorKind) -> IronResult<Response>