Fix typo: DownloadProgessItem to DownloadProgressItem

Author: IAvecilla

src/api/downloader.rs

@@ -35,7 +35,7 @@ pub struct Downloader {
 #[rpc_requests(message = SwarmMsg, alias = "Msg")]
 #[derive(Debug, Serialize, Deserialize)]
 enum SwarmProtocol {
-    #[rpc(tx = mpsc::Sender<DownloadProgessItem>)]
+    #[rpc(tx = mpsc::Sender<DownloadProgressItem>)]
     Download(DownloadRequest),
 }
 
@@ -47,7 +47,7 @@ struct DownloaderActor {
 }
 
 #[derive(Debug, Serialize, Deserialize)]
-pub enum DownloadProgessItem {
+pub enum DownloadProgressItem {
     #[serde(skip)]
     Error(anyhow::Error),
     TryProvider {
@@ -99,15 +99,15 @@ impl DownloaderActor {
 async fn handle_download(store: Store, pool: ConnectionPool, msg: DownloadMsg) {
     let DownloadMsg { inner, mut tx, .. } = msg;
     if let Err(cause) = handle_download_impl(store, pool, inner, &mut tx).await {
-        tx.send(DownloadProgessItem::Error(cause)).await.ok();
+        tx.send(DownloadProgressItem::Error(cause)).await.ok();
     }
 }
 
 async fn handle_download_impl(
     store: Store,
     pool: ConnectionPool,
     request: DownloadRequest,
-    tx: &mut mpsc::Sender<DownloadProgessItem>,
+    tx: &mut mpsc::Sender<DownloadProgressItem>,
 ) -> anyhow::Result<()> {
     match request.strategy {
         SplitStrategy::Split => handle_download_split_impl(store, pool, request, tx).await?,
@@ -128,7 +128,7 @@ async fn handle_download_split_impl(
     store: Store,
     pool: ConnectionPool,
     request: DownloadRequest,
-    tx: &mut mpsc::Sender<DownloadProgessItem>,
+    tx: &mut mpsc::Sender<DownloadProgressItem>,
 ) -> anyhow::Result<()> {
     let providers = request.providers;
     let requests = split_request(&request.request, &providers, &pool, &store, Drain).await?;
@@ -141,7 +141,7 @@ async fn handle_download_split_impl(
             let progress_tx = progress_tx.clone();
             async move {
                 let hash = request.hash;
-                let (tx, rx) = tokio::sync::mpsc::channel::<(usize, DownloadProgessItem)>(16);
+                let (tx, rx) = tokio::sync::mpsc::channel::<(usize, DownloadProgressItem)>(16);
                 progress_tx.send(rx).await.ok();
                 let sink = TokioMpscSenderSink(tx)
                     .with_map_err(io::Error::other)
@@ -157,12 +157,12 @@ async fn handle_download_split_impl(
         into_stream(progress_rx)
             .flat_map(into_stream)
             .map(move |(id, item)| match item {
-                DownloadProgessItem::Progress(offset) => {
+                DownloadProgressItem::Progress(offset) => {
                     total += offset;
                     if let Some(prev) = offsets.insert(id, offset) {
                         total -= prev;
                     }
-                    DownloadProgessItem::Progress(total)
+                    DownloadProgressItem::Progress(total)
                 }
                 x => x,
             })
@@ -177,7 +177,7 @@ async fn handle_download_split_impl(
                     Some((_hash, Ok(()))) => {
                     }
                     Some((_hash, Err(_e))) => {
-                        tx.send(DownloadProgessItem::DownloadError).await?;
+                        tx.send(DownloadProgressItem::DownloadError).await?;
                     }
                     None => break,
                 }
@@ -301,19 +301,19 @@ impl<'de> Deserialize<'de> for DownloadRequest {
 pub type DownloadOptions = DownloadRequest;
 
 pub struct DownloadProgress {
-    fut: future::Boxed<irpc::Result<mpsc::Receiver<DownloadProgessItem>>>,
+    fut: future::Boxed<irpc::Result<mpsc::Receiver<DownloadProgressItem>>>,
 }
 
 impl DownloadProgress {
-    fn new(fut: future::Boxed<irpc::Result<mpsc::Receiver<DownloadProgessItem>>>) -> Self {
+    fn new(fut: future::Boxed<irpc::Result<mpsc::Receiver<DownloadProgressItem>>>) -> Self {
         Self { fut }
     }
 
-    pub async fn stream(self) -> irpc::Result<impl Stream<Item = DownloadProgessItem> + Unpin> {
+    pub async fn stream(self) -> irpc::Result<impl Stream<Item = DownloadProgressItem> + Unpin> {
         let rx = self.fut.await?;
         Ok(Box::pin(rx.into_stream().map(|item| match item {
             Ok(item) => item,
-            Err(e) => DownloadProgessItem::Error(e.into()),
+            Err(e) => DownloadProgressItem::Error(e.into()),
         })))
     }
 
@@ -323,8 +323,8 @@ impl DownloadProgress {
         tokio::pin!(stream);
         while let Some(item) = stream.next().await {
             match item? {
-                DownloadProgessItem::Error(e) => Err(e)?,
-                DownloadProgessItem::DownloadError => anyhow::bail!("Download error"),
+                DownloadProgressItem::Error(e) => Err(e)?,
+                DownloadProgressItem::DownloadError => anyhow::bail!("Download error"),
                 _ => {}
             }
         }
@@ -375,7 +375,7 @@ async fn split_request<'a>(
     providers: &Arc<dyn ContentDiscovery>,
     pool: &ConnectionPool,
     store: &Store,
-    progress: impl Sink<DownloadProgessItem, Error = io::Error>,
+    progress: impl Sink<DownloadProgressItem, Error = io::Error>,
 ) -> anyhow::Result<Box<dyn Iterator<Item = GetRequest> + Send + 'a>> {
     Ok(match request {
         FiniteRequest::Get(req) => {
@@ -431,13 +431,13 @@ async fn execute_get(
     request: Arc<GetRequest>,
     providers: &Arc<dyn ContentDiscovery>,
     store: &Store,
-    mut progress: impl Sink<DownloadProgessItem, Error = io::Error>,
+    mut progress: impl Sink<DownloadProgressItem, Error = io::Error>,
 ) -> anyhow::Result<()> {
     let remote = store.remote();
     let mut providers = providers.find_providers(request.content());
     while let Some(provider) = providers.next().await {
         progress
-            .send(DownloadProgessItem::TryProvider {
+            .send(DownloadProgressItem::TryProvider {
                 id: provider,
                 request: request.clone(),
             })
@@ -450,7 +450,7 @@ async fn execute_get(
         let local_bytes = local.local_bytes();
         let Ok(conn) = conn.await else {
             progress
-                .send(DownloadProgessItem::ProviderFailed {
+                .send(DownloadProgressItem::ProviderFailed {
                     id: provider,
                     request: request.clone(),
                 })
@@ -461,21 +461,21 @@ async fn execute_get(
             .execute_get_sink(
                 &conn,
                 local.missing(),
-                (&mut progress).with_map(move |x| DownloadProgessItem::Progress(x + local_bytes)),
+                (&mut progress).with_map(move |x| DownloadProgressItem::Progress(x + local_bytes)),
             )
             .await
         {
             Ok(_stats) => {
                 progress
-                    .send(DownloadProgessItem::PartComplete {
+                    .send(DownloadProgressItem::PartComplete {
                         request: request.clone(),
                     })
                     .await?;
                 return Ok(());
             }
             Err(_cause) => {
                 progress
-                    .send(DownloadProgessItem::ProviderFailed {
+                    .send(DownloadProgressItem::ProviderFailed {
                         id: provider,
                         request: request.clone(),
                     })