From 12ee7b9b133a1c80a2321b2950ce481628885444 Mon Sep 17 00:00:00 2001
From: mpostma <postma.marin@protonmail.com>
Date: Wed, 30 Dec 2020 19:17:13 +0100
Subject: [PATCH] impl get all updates

---
 src/data/updates.rs | 16 ++++++++++++++++
 src/routes/index.rs | 16 +++++++++++++---
 2 files changed, 29 insertions(+), 3 deletions(-)

diff --git a/src/data/updates.rs b/src/data/updates.rs
index 6bb9b20f2..bb96c53c6 100644
--- a/src/data/updates.rs
+++ b/src/data/updates.rs
@@ -50,4 +50,20 @@ impl Data {
     pub fn get_update_status(&self, _index: &str, uid: u64) -> anyhow::Result<Option<UpdateStatus<UpdateMeta, UpdateResult, String>>> {
         self.update_queue.get_update_status(uid)
     }
+
+    pub fn get_updates_status(&self, _index: &str) -> anyhow::Result<Vec<UpdateStatus<UpdateMeta, UpdateResult, String>>> {
+        let result = self.update_queue.iter_metas(|processing, processed, pending, aborted, failed| {
+            let mut metas = processing
+            .map(UpdateStatus::from)
+            .into_iter()
+            .chain(processed.filter_map(|i| Some(i.ok()?.1)).map(UpdateStatus::from))
+            .chain(pending.filter_map(|i| Some(i.ok()?.1)).map(UpdateStatus::from))
+            .chain(aborted.filter_map(|i| Some(i.ok()?.1)).map(UpdateStatus::from))
+            .chain(failed.filter_map(|i| Some(i.ok()?.1)).map(UpdateStatus::from))
+            .collect::<Vec<_>>();
+            metas.sort_by(|a, b| a.id().cmp(&b.id()));
+            Ok(metas)
+        })?;
+        Ok(result)
+    }
 }
diff --git a/src/routes/index.rs b/src/routes/index.rs
index eb961a8dd..515e771e1 100644
--- a/src/routes/index.rs
+++ b/src/routes/index.rs
@@ -124,8 +124,18 @@ async fn get_update_status(
 
 #[get("/indexes/{index_uid}/updates", wrap = "Authentication::Private")]
 async fn get_all_updates_status(
-    _data: web::Data<Data>,
-    _path: web::Path<IndexParam>,
+    data: web::Data<Data>,
+    path: web::Path<IndexParam>,
 ) -> Result<HttpResponse, ResponseError> {
-    todo!()
+    let result = data.get_updates_status(&path.index_uid);
+    match result {
+        Ok(metas) => {
+            let json = serde_json::to_string(&metas).unwrap();
+            Ok(HttpResponse::Ok().body(json))
+        }
+        Err(e) => {
+            error!("{}", e);
+            todo!()
+        } 
+    }
 }