From 9288783d09f4cc528cd5ca715533dffe2958fbd8 Mon Sep 17 00:00:00 2001
From: ghassmo <ghxxm@protonmail.com>
Date: Fri, 4 Jun 2021 19:43:00 +0300
Subject: [PATCH] cargo fmt

---
 src/bin/darkfid.rs     | 15 ++++-----------
 src/bin/gatewayd.rs    |  2 +-
 src/rocks.rs           |  8 ++++----
 src/service/gateway.rs |  3 ++-
 4 files changed, 11 insertions(+), 17 deletions(-)

diff --git a/src/bin/darkfid.rs b/src/bin/darkfid.rs
index e71ab9f89..4e6d93396 100644
--- a/src/bin/darkfid.rs
+++ b/src/bin/darkfid.rs
@@ -4,7 +4,7 @@ use easy_parallel::Parallel;
 use std::net::SocketAddr;
 
 use drk::service::{ClientProgramOptions, GatewayClient};
-use drk::{slab::Slab, Result, rocks::Rocks};
+use drk::{rocks::Rocks, slab::Slab, Result};
 
 fn setup_addr(address: Option<SocketAddr>, default: SocketAddr) -> SocketAddr {
     match address {
@@ -92,9 +92,9 @@ mod test {
     fn test_darkfid_client() {
         use std::path::Path;
 
+        use drk::rocks::Rocks;
         use drk::service::GatewayClient;
         use drk::slab::Slab;
-        use drk::rocks::Rocks;
 
         use log::*;
         use rand::Rng;
@@ -120,19 +120,13 @@ mod test {
                     let mut rng = rand::thread_rng();
                     let rnd: u32 = rng.gen();
 
-
-
-
                     let path_str = format!("database_{}.db", rnd);
                     let database_path = Path::new(path_str.as_str());
                     let rocks = Rocks::new(database_path.clone()).unwrap();
 
                     // create new client and use different slabstore
-                    let mut client = GatewayClient::new(
-                        "127.0.0.1:3333".parse().unwrap(),
-                        rocks,
-                    )
-                    .unwrap();
+                    let mut client =
+                        GatewayClient::new("127.0.0.1:3333".parse().unwrap(), rocks).unwrap();
 
                     // start client
                     client.start().await.unwrap();
@@ -140,7 +134,6 @@ mod test {
                     // sending slab
                     let _slab = Slab::new("testcoin".to_string(), rnd.to_le_bytes().to_vec());
                     client.put_slab(_slab).await.unwrap();
-                    
                 })
             });
             thread_pools.push(thread);
diff --git a/src/bin/gatewayd.rs b/src/bin/gatewayd.rs
index 7943abc7d..b11d66792 100644
--- a/src/bin/gatewayd.rs
+++ b/src/bin/gatewayd.rs
@@ -5,8 +5,8 @@ extern crate clap;
 use async_executor::Executor;
 use easy_parallel::Parallel;
 
-use drk::{Result, rocks::Rocks};
 use drk::service::{GatewayService, ProgramOptions};
+use drk::{rocks::Rocks, Result};
 
 fn setup_addr(address: Option<SocketAddr>, default: SocketAddr) -> SocketAddr {
     match address {
diff --git a/src/rocks.rs b/src/rocks.rs
index 3b1a89ee8..d1bb7501d 100644
--- a/src/rocks.rs
+++ b/src/rocks.rs
@@ -2,11 +2,11 @@ use std::path::Path;
 
 use crate::{Error, Result};
 
-use rocksdb::{ColumnFamilyDescriptor, Options, DB, ColumnFamily};
+use rocksdb::{ColumnFamily, ColumnFamilyDescriptor, Options, DB};
 
-pub enum IteratorMode{
+pub enum IteratorMode {
     Start,
-    End
+    End,
 }
 
 pub trait Column {
@@ -91,7 +91,7 @@ impl Rocks {
         Ok(true)
     }
 
-    pub fn iterator(&self, cf: &ColumnFamily, iterator_mode: IteratorMode) -> rocksdb::DBIterator{
+    pub fn iterator(&self, cf: &ColumnFamily, iterator_mode: IteratorMode) -> rocksdb::DBIterator {
         let iterator_mode = match iterator_mode {
             IteratorMode::Start => rocksdb::IteratorMode::Start,
             IteratorMode::End => rocksdb::IteratorMode::End,
diff --git a/src/service/gateway.rs b/src/service/gateway.rs
index 6f59dbdcc..19ef41d13 100644
--- a/src/service/gateway.rs
+++ b/src/service/gateway.rs
@@ -4,7 +4,8 @@ use std::net::SocketAddr;
 
 use super::reqrep::{PeerId, Publisher, RepProtocol, Reply, ReqProtocol, Request, Subscriber};
 use crate::{
-    serial::deserialize, serial::serialize, slab::Slab, slabstore::SlabStore, Error, Result, rocks::Rocks
+    rocks::Rocks, serial::deserialize, serial::serialize, slab::Slab, slabstore::SlabStore, Error,
+    Result,
 };
 
 use async_executor::Executor;