rust fmt & clippy fixes

Author: elpiel

validator_worker/src/producer.rs

@@ -2,9 +2,9 @@ use std::error::Error;
 
 use chrono::{TimeZone, Utc};
 
-use primitives::{BalancesMap, Channel};
 use primitives::adapter::Adapter;
 use primitives::validator::{Accounting, MessageTypes};
+use primitives::{BalancesMap, Channel};
 
 use crate::core::events::merge_aggrs;
 use crate::sentry_interface::SentryApi;
@@ -14,20 +14,22 @@ pub type Result = std::result::Result<(BalancesMap, Option<MessageTypes>), Box<d
 pub async fn tick<A: Adapter + 'static>(iface: &SentryApi<A>) -> Result {
     let validator_msg_resp = await!(iface.get_our_latest_msg("Accounting".to_owned()))?;
 
-    let accounting = validator_msg_resp.msg.get(0).and_then(|accounting| match accounting {
-        MessageTypes::Accounting(accounting) => Some(accounting.to_owned()),
-        _ => None,
-    }).unwrap_or_else(|| {
-        Accounting {
+    let accounting = validator_msg_resp
+        .msg
+        .get(0)
+        .and_then(|accounting| match accounting {
+            MessageTypes::Accounting(accounting) => Some(accounting.to_owned()),
+            _ => None,
+        })
+        .unwrap_or_else(|| Accounting {
             last_event_aggregate: Utc.timestamp(0, 0),
             balances_before_fees: Default::default(),
             balances: Default::default(),
-        }
-    });
+        });
 
     let aggrs = await!(iface.get_event_aggregates(accounting.last_event_aggregate))?;
 
-    if aggrs.events.len() > 0 {
+    if !aggrs.events.is_empty() {
         // TODO: Log the merge
         let (balances, new_accounting) = merge_aggrs(&accounting, &aggrs.events, &iface.channel)?;