From 8efa7d0bfbefce60e3d13c0e0bc70b08fff1b827 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Imobach=20Gonz=C3=A1lez=20Sosa?= <igonzalezsosa@suse.com>
Date: Wed, 29 May 2024 11:34:48 +0100
Subject: [PATCH 1/3] fix(rust): avoid a long-lived probing request

---
 rust/agama-server/src/manager/web.rs | 31 +++++++++++++++++++++++-----
 1 file changed, 26 insertions(+), 5 deletions(-)

diff --git a/rust/agama-server/src/manager/web.rs b/rust/agama-server/src/manager/web.rs
index dd238f4b4e..55bbea3468 100644
--- a/rust/agama-server/src/manager/web.rs
+++ b/rust/agama-server/src/manager/web.rs
@@ -33,6 +33,7 @@ use crate::{
 
 #[derive(Clone)]
 pub struct ManagerState<'a> {
+    dbus: zbus::Connection,
     manager: ManagerClient<'a>,
 }
 
@@ -86,8 +87,8 @@ pub async fn manager_service(dbus: zbus::Connection) -> Result<Router, ServiceEr
 
     let status_router = service_status_router(&dbus, DBUS_SERVICE, DBUS_PATH).await?;
     let progress_router = progress_router(&dbus, DBUS_SERVICE, DBUS_PATH).await?;
-    let manager = ManagerClient::new(dbus).await?;
-    let state = ManagerState { manager };
+    let manager = ManagerClient::new(dbus.clone()).await?;
+    let state = ManagerState { manager, dbus };
     Ok(Router::new()
         .route("/probe", post(probe_action))
         .route("/install", post(install_action))
@@ -100,16 +101,36 @@ pub async fn manager_service(dbus: zbus::Connection) -> Result<Router, ServiceEr
 }
 
 /// Starts the probing process.
+// The Probe D-Bus method is blocking and will not return until the probing is finished. To avoid a
+// long-lived HTTP connection, this method returns immediately (with a 200) and runs the request on
+// a separate task.
 #[utoipa::path(
     get,
     path = "/probe",
     context_path = "/api/manager",
     responses(
-      (status = 200, description = "The probing process was started.")
+      (
+          status = 200,
+          description = "The probing was requested but there is no way to know whether it succeed."
+       )
     )
 )]
-async fn probe_action(State(state): State<ManagerState<'_>>) -> Result<(), Error> {
-    state.manager.probe().await?;
+async fn probe_action<'a>(State(state): State<ManagerState<'a>>) -> Result<(), Error> {
+    let dbus = state.dbus.clone();
+    tokio::spawn(async move {
+        let result = dbus
+            .call_method(
+                Some("org.opensuse.Agama.Manager1"),
+                "/org/opensuse/Agama/Manager1",
+                Some("org.opensuse.Agama.Manager1"),
+                "Probe",
+                &(),
+            )
+            .await;
+        if let Err(error) = result {
+            tracing::error!("Could not start probing: {:?}", error);
+        }
+    });
     Ok(())
 }
 

From ff3c86da806255e74710ba924839ca3dea0082ec Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Imobach=20Gonz=C3=A1lez=20Sosa?= <igonzalezsosa@suse.com>
Date: Wed, 29 May 2024 11:41:12 +0100
Subject: [PATCH 2/3] chore(rust): update the changes file

---
 rust/package/agama.changes | 6 ++++++
 1 file changed, 6 insertions(+)

diff --git a/rust/package/agama.changes b/rust/package/agama.changes
index 7d29bb8d4a..f391b375d3 100644
--- a/rust/package/agama.changes
+++ b/rust/package/agama.changes
@@ -1,3 +1,9 @@
+-------------------------------------------------------------------
+Wed May 29 10:40:21 UTC 2024 - Imobach Gonzalez Sosa <igonzalezsosa@suse.com>
+
+- The HTTP request to perform a probing is not blocking anymore
+  (gh#openSUSE/agama#1272).
+
 -------------------------------------------------------------------
 Mon May 27 14:11:55 UTC 2024 - Imobach Gonzalez Sosa <igonzalezsosa@suse.com>
 

From 0411f0aa05e85022b0fbeee35586498dec13bc94 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Imobach=20Gonz=C3=A1lez=20Sosa?= <igonzalezsosa@suse.com>
Date: Wed, 29 May 2024 11:52:08 +0100
Subject: [PATCH 3/3] chore(doc): fix a typo in probing description

---
 rust/agama-server/src/manager/web.rs | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/rust/agama-server/src/manager/web.rs b/rust/agama-server/src/manager/web.rs
index 55bbea3468..bdfac34c0d 100644
--- a/rust/agama-server/src/manager/web.rs
+++ b/rust/agama-server/src/manager/web.rs
@@ -111,7 +111,7 @@ pub async fn manager_service(dbus: zbus::Connection) -> Result<Router, ServiceEr
     responses(
       (
           status = 200,
-          description = "The probing was requested but there is no way to know whether it succeed."
+          description = "The probing was requested but there is no way to know whether it succeeded."
        )
     )
 )]