fix(command): Code style fixes

src/command.rs

@@ -50,9 +50,13 @@ async fn serve() -> Result<(), Error> {
 }
 
 async fn send_resource(url: &str) -> Result<(), Error> {
-    send_resource::send_resource(url).await.map_err(Error::SendResource)
+    send_resource::send_resource(url)
+        .await
+        .map_err(Error::SendResource)
 }
 
 async fn consume(url: &str) -> Result<(), Error> {
-    rabbitmq_consumer::consume(url).await.map_err(Error::Consume)
+    rabbitmq_consumer::consume(url)
+        .await
+        .map_err(Error::Consume)
 }

src/send_resource.rs

@@ -11,14 +11,18 @@ pub enum Error {
 
 pub async fn send_resource(url: &str) -> Result<(), Error> {
     let resource_vec: Vec<Value> =
-        serde_json::from_str(MANGALIB_STATIC_RESOURCE).map_err(|err| Error::Parse(err))?;
+        serde_json::from_str(MANGALIB_STATIC_RESOURCE).map_err(Error::Parse)?;
 
     let mut handlers = Vec::new();
     for res in resource_vec {
         let res_cloned = res.clone();
         let url_cloned = url.to_string();
         let handler = tokio::spawn(async move {
-            let sending_result = Client::new().post(&url_cloned).json(&res_cloned).send().await;
+            let sending_result = Client::new()
+                .post(&url_cloned)
+                .json(&res_cloned)
+                .send()
+                .await;
 
             match sending_result {
                 Ok(_) => {

src/server.rs

@@ -37,7 +37,10 @@ pub async fn serve() -> Result<(), Error> {
         .parse::<u16>()
         .map_err(|err| Error::Config(ConfigErrorType::ParseInt(err)))?;
 
-    let state = AppState { port, chrome_max_count };
+    let state = AppState {
+        port,
+        chrome_max_count,
+    };
     let address = &format!("0.0.0.0:{}", state.port.clone());
     let listener = TcpListener::bind(address)
         .await
@@ -49,7 +52,8 @@ pub async fn serve() -> Result<(), Error> {
         .fallback(handle_404);
 
     info!("Web server is up: {address}");
-    axum::serve(listener, router).await
+    axum::serve(listener, router)
+        .await
         .map_err(Error::ServerError)?;
 
     Ok(())