style: use formatters

xrelkd · xrelkd · commit 560cf9a6c8c8 · 2026-01-27T13:46:03.000+08:00
diff --git a/caracal-tui/src/tui/ui/pages/status/components/information.rs b/caracal-tui/src/tui/ui/pages/status/components/information.rs
@@ -1,5 +1,5 @@
 use crossterm::event::KeyEvent;
-use ratatui::{prelude::*, widgets::Paragraph, Frame};
+use ratatui::{Frame, prelude::*, widgets::Paragraph};
 use tokio::sync::mpsc::UnboundedSender;
 
 use crate::tui::{
@@ -53,19 +53,23 @@ pub struct RenderProps {
 
 impl ComponentRender<RenderProps> for InformationArea {
     fn render(&self, frame: &mut Frame<'_>, props: RenderProps) {
-        let [info_keys_container, info_values_container, keybind_keys_container, keybind_values_container] =
-            *Layout::default()
-                .direction(Direction::Horizontal)
-                .constraints(
-                    [
-                        Constraint::Percentage(10),
-                        Constraint::Percentage(30),
-                        Constraint::Max(10),
-                        Constraint::Percentage(15),
-                    ]
-                    .as_ref(),
-                )
-                .split(props.area)
+        let [
+            info_keys_container,
+            info_values_container,
+            keybind_keys_container,
+            keybind_values_container,
+        ] = *Layout::default()
+            .direction(Direction::Horizontal)
+            .constraints(
+                [
+                    Constraint::Percentage(10),
+                    Constraint::Percentage(30),
+                    Constraint::Max(10),
+                    Constraint::Percentage(15),
+                ]
+                .as_ref(),
+            )
+            .split(props.area)
         else {
             panic!("The main layout should have 5 chunks")
         };
diff --git a/caracal-tui/src/tui/ui/pages/status/components/task_status.rs b/caracal-tui/src/tui/ui/pages/status/components/task_status.rs
@@ -3,10 +3,10 @@ use std::time::SystemTime;
 use caracal_base::{ext::ProgressChunks, model};
 use crossterm::event::{KeyCode, KeyEvent, KeyEventKind, KeyModifiers};
 use ratatui::{
+    Frame,
     prelude::*,
     style::{Modifier, Style},
     widgets::{Block, Borders, Cell, Row, Table, TableState},
-    Frame,
 };
 use tokio::sync::mpsc::UnboundedSender;
 
@@ -41,13 +41,10 @@ impl TaskStatusList {
             return;
         }
 
-        let i = self.table_state.selected().map_or(0, |i| {
-            if i >= self.task_statuses().len() - 1 {
-                0
-            } else {
-                i + 1
-            }
-        });
+        let i = self
+            .table_state
+            .selected()
+            .map_or(0, |i| if i >= self.task_statuses().len() - 1 { 0 } else { i + 1 });
         self.table_state.select(Some(i));
     }
 
@@ -57,13 +54,10 @@ impl TaskStatusList {
             return;
         }
 
-        let i = self.table_state.selected().map_or(0, |i| {
-            if i == 0 {
-                self.task_statuses().len() - 1
-            } else {
-                i - 1
-            }
-        });
+        let i = self
+            .table_state
+            .selected()
+            .map_or(0, |i| if i == 0 { self.task_statuses().len() - 1 } else { i - 1 });
         self.table_state.select(Some(i));
     }
 
@@ -184,18 +178,10 @@ impl ComponentRender<RenderProps> for TaskStatusList {
             let received_bytes = status.chunks.received_bytes();
             let total_bytes = {
                 let v = status.chunks.total_bytes();
-                if v < received_bytes {
-                    received_bytes
-                } else {
-                    v
-                }
+                if v < received_bytes { received_bytes } else { v }
             };
             let progress_percentage = if total_bytes == 0 {
-                if received_bytes == 0 {
-                    String::from("0.00%")
-                } else {
-                    String::from("100.00%")
-                }
+                if received_bytes == 0 { String::from("0.00%") } else { String::from("100.00%") }
             } else {
                 format!("{:.2}%", (received_bytes as f64 / total_bytes as f64) * 100.0)
             };
diff --git a/caracal-tui/src/tui/ui/pages/status/mod.rs b/caracal-tui/src/tui/ui/pages/status/mod.rs
@@ -2,8 +2,8 @@ mod components;
 
 use crossterm::event::{KeyCode, KeyEvent, KeyEventKind, KeyModifiers};
 use ratatui::{
-    layout::{Constraint, Direction, Layout},
     Frame,
+    layout::{Constraint, Direction, Layout},
 };
 use tokio::sync::mpsc;
 
diff --git a/caracal-tui/src/tui/ui/ui_manager.rs b/caracal-tui/src/tui/ui/ui_manager.rs
@@ -8,14 +8,14 @@ use tokio::sync::mpsc;
 use tokio_stream::StreamExt;
 
 use crate::tui::{
+    State,
     state_store::Action,
     ui::{
+        Error,
         components::{Component, ComponentRender},
         error,
         pages::AppRouter,
-        Error,
     },
-    State,
 };
 
 const RENDERING_TICK_RATE: Duration = Duration::from_millis(250);
diff --git a/caracal/src/cli/ui.rs b/caracal/src/cli/ui.rs
@@ -1,7 +1,7 @@
 use std::time::SystemTime;
 
 use caracal_base::{ext::ProgressChunks, model};
-use comfy_table::{presets::UTF8_FULL, Cell, ContentArrangement, Row, Table, TableComponent};
+use comfy_table::{Cell, ContentArrangement, Row, Table, TableComponent, presets::UTF8_FULL};
 
 // SAFETY: the precision loss is acceptable
 #[allow(clippy::cast_precision_loss)]
@@ -21,18 +21,10 @@ pub fn render_task_statuses_table(task_statuses: &[model::TaskStatus]) -> String
         let received_bytes = status.chunks.received_bytes();
         let total_bytes = {
             let v = status.chunks.total_bytes();
-            if v < received_bytes {
-                received_bytes
-            } else {
-                v
-            }
+            if v < received_bytes { received_bytes } else { v }
         };
         let progress_percentage = if total_bytes == 0 {
-            if received_bytes == 0 {
-                String::from("0.00%")
-            } else {
-                String::from("100.00%")
-            }
+            if received_bytes == 0 { String::from("0.00%") } else { String::from("100.00%") }
         } else {
             format!("{:.2}%", (received_bytes as f64 / total_bytes as f64) * 100.0)
         };
diff --git a/crates/cli/src/config/log.rs b/crates/cli/src/config/log.rs
@@ -1,9 +1,9 @@
 use std::{fs::OpenOptions, path::PathBuf};
 
 use serde::{Deserialize, Serialize};
-use serde_with::{serde_as, DisplayFromStr};
+use serde_with::{DisplayFromStr, serde_as};
 use tracing_subscriber::{
-    layer::SubscriberExt, registry::LookupSpan, util::SubscriberInitExt, Layer,
+    Layer, layer::SubscriberExt, registry::LookupSpan, util::SubscriberInitExt,
 };
 
 #[serde_as]
diff --git a/crates/engine/src/downloader/factory.rs b/crates/engine/src/downloader/factory.rs
@@ -2,21 +2,21 @@ use std::{
     collections::HashMap,
     fmt,
     path::{Path, PathBuf},
-    sync::{atomic::AtomicBool, Arc},
+    sync::{Arc, atomic::AtomicBool},
     time::Duration,
 };
 
 use caracal_base::{
     model,
     profile::{minio::MinioAlias, ssh::SshConfig},
 };
-use futures::{future, FutureExt};
+use futures::{FutureExt, future};
 use snafu::{OptionExt, ResultExt};
 use tokio::fs::OpenOptions;
 
 pub use crate::error::Error;
 use crate::{
-    downloader::{control_file::ControlFile, Downloader, TransferStatus},
+    downloader::{Downloader, TransferStatus, control_file::ControlFile},
     error,
     ext::UriExt,
     fetcher::Fetcher,
diff --git a/crates/engine/src/downloader/worker.rs b/crates/engine/src/downloader/worker.rs
@@ -5,7 +5,7 @@ use snafu::ResultExt;
 use tokio::{
     fs::File,
     io::{AsyncSeekExt, AsyncWriteExt},
-    sync::{mpsc, oneshot, Mutex},
+    sync::{Mutex, mpsc, oneshot},
 };
 
 use crate::{
diff --git a/crates/engine/src/fetcher/fs.rs b/crates/engine/src/fetcher/fs.rs
@@ -1,13 +1,13 @@
 use std::path::{Path, PathBuf};
 
-use opendal::{services, Operator};
+use opendal::{Operator, services};
 use snafu::ResultExt;
 
 use crate::{
     error,
     error::{Error, Result},
     ext::PathExt,
-    fetcher::{generic::ByteStream, Metadata},
+    fetcher::{Metadata, generic::ByteStream},
 };
 
 #[derive(Clone, Debug)]
diff --git a/crates/engine/src/fetcher/generic.rs b/crates/engine/src/fetcher/generic.rs
@@ -22,11 +22,7 @@ impl ByteStream {
 
         let n = self.reader.read_buf(&mut self.buffer).await.context(error::ReadFromReaderSnafu)?;
 
-        if n == 0 {
-            Ok(None)
-        } else {
-            Ok(Some(self.buffer.as_ref()))
-        }
+        if n == 0 { Ok(None) } else { Ok(Some(self.buffer.as_ref())) }
     }
 
     #[inline]
diff --git a/crates/engine/src/fetcher/http.rs b/crates/engine/src/fetcher/http.rs
@@ -1,5 +1,5 @@
 use bytes::Bytes;
-use reqwest::{header, StatusCode};
+use reqwest::{StatusCode, header};
 use snafu::ResultExt;
 
 use crate::{
diff --git a/crates/engine/src/fetcher/minio.rs b/crates/engine/src/fetcher/minio.rs
@@ -1,12 +1,12 @@
 use std::{fmt, path::PathBuf};
 
-use opendal::{services, Operator};
+use opendal::{Operator, services};
 use snafu::ResultExt;
 
 use crate::{
     error,
     error::Result,
-    fetcher::{generic::ByteStream, Metadata},
+    fetcher::{Metadata, generic::ByteStream},
 };
 
 #[derive(Clone, Debug)]
diff --git a/crates/engine/src/fetcher/sftp.rs b/crates/engine/src/fetcher/sftp.rs
@@ -1,13 +1,13 @@
 use std::{fmt, path::PathBuf};
 
-use opendal::{services, Operator};
+use opendal::{Operator, services};
 use snafu::ResultExt;
 
 use crate::{
     error,
     error::{Error, Result},
     ext::PathExt,
-    fetcher::{generic::ByteStream, Metadata},
+    fetcher::{Metadata, generic::ByteStream},
 };
 
 #[derive(Clone, Debug)]
diff --git a/crates/engine/src/task_scheduler/worker.rs b/crates/engine/src/task_scheduler/worker.rs
@@ -5,11 +5,11 @@ use std::{
 };
 
 use caracal_base::model;
-use futures::{future, FutureExt};
+use futures::{FutureExt, future};
 use tokio::sync::{mpsc, oneshot};
 
 use crate::{
-    downloader::DownloaderFactory, ext::UriExt, task_scheduler::Event, Downloader, DownloaderStatus,
+    Downloader, DownloaderStatus, downloader::DownloaderFactory, ext::UriExt, task_scheduler::Event,
 };
 
 #[derive(Debug)]
diff --git a/crates/grpc-client/src/system.rs b/crates/grpc-client/src/system.rs
@@ -1,7 +1,7 @@
 use caracal_proto as proto;
 use tonic::Request;
 
-use crate::{error::GetSystemVersionError, Client};
+use crate::{Client, error::GetSystemVersionError};
 
 pub trait System {
     async fn get_version(&self) -> Result<semver::Version, GetSystemVersionError>;
diff --git a/crates/grpc-client/src/task.rs b/crates/grpc-client/src/task.rs
@@ -5,12 +5,12 @@ use caracal_proto as proto;
 use tonic::Request;
 
 use crate::{
+    Client,
     error::{
         AddUriError, DecreaseConcurrentNumberError, GetAllTaskStatusesError, GetTaskStatusError,
         IncreaseConcurrentNumberError, PauseAllTasksError, PauseTaskError, RemoveTaskError,
         ResumeAllTasksError, ResumeTaskError,
     },
-    Client,
 };
 
 pub trait Task {
diff --git a/crates/metrics/src/server.rs b/crates/metrics/src/server.rs
@@ -1,11 +1,12 @@
 use std::{future::Future, net::SocketAddr, str::FromStr, sync::LazyLock};
 
 use axum::{
+    Router,
     body::Body,
     extract::Extension,
-    http::{header, HeaderValue},
+    http::{HeaderValue, header},
     response::Response,
-    routing, Router,
+    routing,
 };
 use bytes::{BufMut, BytesMut};
 use prometheus::{Encoder, TextEncoder};
diff --git a/crates/proto/src/lib.rs b/crates/proto/src/lib.rs
@@ -29,16 +29,16 @@ use caracal_base::model;
 
 pub use self::{
     proto::{
-        system_client::SystemClient,
-        system_server::{System, SystemServer},
-        task_client::TaskClient,
-        task_server::{Task, TaskServer},
         AddUriRequest, AddUriResponse, Chunk, DecreaseConcurrentNumberRequest,
         DecreaseConcurrentNumberResponse, GetAllTaskStatusesResponse, GetSystemVersionResponse,
         GetTaskStatusRequest, GetTaskStatusResponse, IncreaseConcurrentNumberRequest,
         IncreaseConcurrentNumberResponse, PauseAllTasksResponse, PauseTaskRequest,
         PauseTaskResponse, Priority, RemoveTaskRequest, RemoveTaskResponse, ResumeAllTasksResponse,
         ResumeTaskRequest, ResumeTaskResponse, TaskMetadata, TaskState, TaskStatus,
+        system_client::SystemClient,
+        system_server::{System, SystemServer},
+        task_client::TaskClient,
+        task_server::{Task, TaskServer},
     },
     utils::{datetime_to_timestamp, timestamp_to_datetime},
 };
diff --git a/crates/server/src/grpc/interceptor.rs b/crates/server/src/grpc/interceptor.rs
@@ -1,6 +1,6 @@
 use std::fmt;
 
-use tonic::{metadata::AsciiMetadataValue, Request, Status};
+use tonic::{Request, Status, metadata::AsciiMetadataValue};
 
 use crate::metrics;
 
diff --git a/crates/server/src/web/controller/system/mod.rs b/crates/server/src/web/controller/system/mod.rs
@@ -1,6 +1,6 @@
 mod v1;
 
-use axum::{routing, Router};
+use axum::{Router, routing};
 
 pub fn v1() -> Router {
     Router::new().nest("/v1/system", Router::new().route("/version", routing::get(v1::get_version)))
diff --git a/crates/server/src/web/controller/task/mod.rs b/crates/server/src/web/controller/task/mod.rs
@@ -1,6 +1,6 @@
 mod v1;
 
-use axum::{routing, Router};
+use axum::{Router, routing};
 
 pub fn v1() -> Router {
     Router::new().nest(
