Rust fmt on the code base (#216)

Author: curquiza

examples/web_app/src/document.rs

@@ -23,7 +23,6 @@ impl Document for Crate {
     }
 }
 
-
 fn get_readable_download_count(this: &Map<String, Value>) -> String {
     if let Some(downloads) = this["downloads"].as_f64() {
         if downloads < 1000.0 {
@@ -39,7 +38,10 @@ fn get_readable_download_count(this: &Map<String, Value>) -> String {
 }
 
 pub fn display(this: &Map<String, Value>) -> Html {
-    let mut url = format!("https://lib.rs/crates/{}", this["name"].as_str().unwrap_or_default());
+    let mut url = format!(
+        "https://lib.rs/crates/{}",
+        this["name"].as_str().unwrap_or_default()
+    );
     url = url.replace("<em>", "");
     url = url.replace("</em>", "");
 

examples/web_app/src/lib.rs

@@ -1,4 +1,5 @@
 #![recursion_limit = "512"]
+use lazy_static::lazy_static;
 use meilisearch_sdk::{
     client::Client,
     indexes::Index,
@@ -9,10 +10,9 @@ use std::rc::Rc;
 use wasm_bindgen::prelude::*;
 use wasm_bindgen_futures::spawn_local;
 use yew::prelude::*;
-use lazy_static::lazy_static;
 
 mod document;
-use crate::document::{Crate, display};
+use crate::document::{display, Crate};
 
 lazy_static! {
     static ref CLIENT: Client = Client::new(
@@ -36,7 +36,11 @@ enum Msg {
     /// An event sent to update the results with a query
     Input(String),
     /// The event sent to display new results once they are received
-    Update{results: Vec<Map<String, Value>>, processing_time_ms: usize, request_id: usize},
+    Update {
+        results: Vec<Map<String, Value>>,
+        processing_time_ms: usize,
+        request_id: usize,
+    },
 }
 
 impl Component for Model {
@@ -87,17 +91,21 @@ impl Component for Model {
                     }
 
                     // We send a new event with the up-to-date data so that we can update the results and display them.
-                    link.send_message(Msg::Update{
+                    link.send_message(Msg::Update {
                         results: fresh_formatted_results,
                         processing_time_ms: fresh_results.processing_time_ms,
-                        request_id
+                        request_id,
                     });
                 });
                 false
             }
 
             // Sent when new results are received
-            Msg::Update{results, processing_time_ms, request_id} => {
+            Msg::Update {
+                results,
+                processing_time_ms,
+                request_id,
+            } => {
                 if request_id >= self.latest_sent_request_id {
                     self.results = results;
                     self.processing_time_ms = processing_time_ms;

src/client.rs

@@ -1,6 +1,6 @@
 use crate::{errors::*, indexes::*, request::*, Rc};
+use serde::Deserialize;
 use serde_json::{json, Value};
-use serde::{Deserialize};
 use std::collections::HashMap;
 
 /// The top-level struct of the SDK, representing a client containing [indexes](../indexes/struct.Index.html).
@@ -25,7 +25,7 @@ impl Client {
     pub fn new(host: impl Into<String>, api_key: impl Into<String>) -> Client {
         Client {
             host: Rc::new(host.into()),
-            api_key: Rc::new(api_key.into())
+            api_key: Rc::new(api_key.into()),
         }
     }
 
@@ -44,8 +44,8 @@ impl Client {
     /// # });
     /// ```
     pub async fn list_all_indexes(&self) -> Result<Vec<Index>, Error> {
-        match self.list_all_indexes_raw().await{
-            Ok (json_indexes) => Ok({
+        match self.list_all_indexes_raw().await {
+            Ok(json_indexes) => Ok({
                 let mut indexes = Vec::new();
                 for json_index in json_indexes {
                     indexes.push(json_index.into_index(self))
@@ -76,7 +76,8 @@ impl Client {
             &self.api_key,
             Method::Get,
             200,
-        ).await?;
+        )
+        .await?;
 
         Ok(json_indexes)
     }
@@ -99,7 +100,7 @@ impl Client {
     /// ```
     pub async fn get_index(&self, uid: impl AsRef<str>) -> Result<Index, Error> {
         match self.get_raw_index(uid).await {
-            Ok (raw_idx) => Ok(raw_idx.into_index(self)),
+            Ok(raw_idx) => Ok(raw_idx.into_index(self)),
             Err(error) => Err(error),
         }
     }
@@ -130,7 +131,7 @@ impl Client {
         Index {
             uid: Rc::new(uid.into()),
             host: Rc::clone(&self.host),
-            api_key: Rc::clone(&self.api_key)
+            api_key: Rc::clone(&self.api_key),
         }
     }
 
@@ -165,16 +166,17 @@ impl Client {
                 "primaryKey": primary_key,
             })),
             201,
-        ).await?
+        )
+        .await?
         .into_index(self))
     }
 
     /// Delete an index from its UID if it exists.
     /// To delete an index if it exists from the [`Index`] object, use the [Index::delete_if_exists] method.
     pub async fn delete_index_if_exists(&self, uid: &str) -> Result<bool, Error> {
         match self.delete_index(uid).await {
-            Ok (_) => Ok(true),
-            Err (Error::MeiliSearchError {
+            Ok(_) => Ok(true),
+            Err(Error::MeiliSearchError {
                 error_message: _,
                 error_code: ErrorCode::IndexNotFound,
                 error_type: _,
@@ -192,7 +194,8 @@ impl Client {
             &self.api_key,
             Method::Delete,
             204,
-        ).await?)
+        )
+        .await?)
     }
 
     /// This will try to get an index and create the index if it does not exist.
@@ -232,7 +235,8 @@ impl Client {
             &self.api_key,
             Method::Get,
             200,
-        ).await
+        )
+        .await
     }
 
     /// Get health of MeiliSearch server.
@@ -296,7 +300,8 @@ impl Client {
             &self.api_key,
             Method::Get,
             200,
-        ).await
+        )
+        .await
     }
 
     /// Get version of the MeiliSearch server.
@@ -317,7 +322,8 @@ impl Client {
             &self.api_key,
             Method::Get,
             200,
-        ).await
+        )
+        .await
     }
 }
 
@@ -373,7 +379,7 @@ pub struct Version {
 
 #[cfg(test)]
 mod tests {
-    use crate::{client::*};
+    use crate::client::*;
     use futures_await_test::async_test;
 
     #[async_test]
@@ -462,7 +468,10 @@ mod tests {
     async fn test_get_primary_key() {
         let client = Client::new("http://localhost:7700", "masterKey");
         let index_name = "get_primary_key";
-        client.create_index(index_name, Some("primary_key")).await.unwrap();
+        client
+            .create_index(index_name, Some("primary_key"))
+            .await
+            .unwrap();
         let primary_key = client.index(index_name).get_primary_key().await;
         assert!(primary_key.is_ok());
         assert_eq!(primary_key.unwrap().unwrap(), "primary_key");

src/dumps.rs

@@ -61,7 +61,7 @@ pub struct DumpInfo {
     pub error: Option<serde_json::Value>,
     pub started_at: Option<String>,
     #[serde(skip_serializing_if = "Option::is_none")]
-    pub finished_at: Option<String>
+    pub finished_at: Option<String>,
 }
 
 /// Dump related methods.\

src/errors.rs

@@ -94,7 +94,6 @@ pub enum ErrorCode {
     Unknown(UnknownErrorCode),
 }
 
-
 #[derive(Clone)]
 pub struct UnknownErrorCode(String);
 
@@ -258,7 +257,6 @@ impl std::error::Error for Error {}
 
 impl From<&serde_json::Value> for Error {
     fn from(json: &serde_json::Value) -> Error {
-
         let error_message = json
             .get("message")
             .and_then(|v| v.as_str())