[PATCH proxmox v4 1/3] rest-server: add request logfilter by method and path in h2 service

[Christian Ebner <c.ebner@proxmox.com>]

Allows to optionally filter incoming requests to be excluded from the
task log. The filter method is provided on instantiation and passes
the request method and path.

A first usecase for this is to filter out HTTP level heartbeat
requests send by the client's backup reader/writer implementation in
order to avoid log flodding.

Signed-off-by: Christian Ebner <c.ebner@proxmox.com>
---
 proxmox-rest-server/src/h2service.rs | 21 +++++++++++++++++++--
 1 file changed, 19 insertions(+), 2 deletions(-)

diff --git a/proxmox-rest-server/src/h2service.rs b/proxmox-rest-server/src/h2service.rs
index b5edc703..5d53d2e4 100644
--- a/proxmox-rest-server/src/h2service.rs
+++ b/proxmox-rest-server/src/h2service.rs
@@ -16,6 +16,8 @@ use proxmox_router::{ApiResponseFuture, HttpError, Router, RpcEnvironment};
 use crate::formatter::*;
 use crate::{WorkerTask, normalize_path_with_components};
 
+type LogFilterFn = Arc<dyn Fn(&hyper::Method, &str) -> bool + Send + Sync>;
+
 /// Hyper Service implementation to handle stateful H2 connections.
 ///
 /// We use this kind of service to handle backup protocol
@@ -27,15 +29,23 @@ pub struct H2Service<E> {
     rpcenv: E,
     worker: Arc<WorkerTask>,
     debug: bool,
+    log_filter: Option<LogFilterFn>,
 }
 
 impl<E: RpcEnvironment + Clone> H2Service<E> {
-    pub fn new(rpcenv: E, worker: Arc<WorkerTask>, router: &'static Router, debug: bool) -> Self {
+    pub fn new(
+        rpcenv: E,
+        worker: Arc<WorkerTask>,
+        router: &'static Router,
+        debug: bool,
+        log_filter: Option<LogFilterFn>,
+    ) -> Self {
         Self {
             rpcenv,
             worker,
             router,
             debug,
+            log_filter,
         }
     }
 
@@ -55,7 +65,14 @@ impl<E: RpcEnvironment + Clone> H2Service<E> {
             Err(err) => return future::err(http_err!(BAD_REQUEST, "{}", err)).boxed(),
         };
 
-        self.debug(format!("{method} {path}"));
+        if self
+            .log_filter
+            .clone()
+            .map(|filter| filter(&method, &path))
+            .unwrap_or(true)
+        {
+            self.debug(format!("{method} {path}"));
+        }
 
         let mut uri_param = HashMap::new();
 
-- 
2.47.3