From c48dc049096da02be6d10919be8d2194aaf090b1 Mon Sep 17 00:00:00 2001
From: yuyr <yuyr@zgclab.edu.cn>
Date: Sat, 18 Jul 2026 10:40:51 +0800
Subject: [PATCH] =?UTF-8?q?20260718=20=E6=A0=BC=E5=BC=8F=E5=8C=96=E6=9F=A5?=
 =?UTF-8?q?=E8=AF=A2=E6=9C=8D=E5=8A=A1=E4=BB=A3=E7=A0=81?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/bin/rpki_query_service.rs | 10 ++++++++--
 src/query/report_stream.rs    |  3 +--
 2 files changed, 9 insertions(+), 4 deletions(-)

diff --git a/src/bin/rpki_query_service.rs b/src/bin/rpki_query_service.rs
index d19163c..5e9947d 100644
--- a/src/bin/rpki_query_service.rs
+++ b/src/bin/rpki_query_service.rs
@@ -2104,8 +2104,14 @@ fn object_filter_from_query(query: &BTreeMap<String, String>) -> Result<ObjectFi
         filter.object_type = Some(normalized.to_string());
     }
     if let Some(value) = query.get("result") {
-        if !matches!(value.to_ascii_lowercase().as_str(), "ok" | "error" | "skipped") {
-            return Err(ApiError::new(400, format!("invalid result filter: {value}")));
+        if !matches!(
+            value.to_ascii_lowercase().as_str(),
+            "ok" | "error" | "skipped"
+        ) {
+            return Err(ApiError::new(
+                400,
+                format!("invalid result filter: {value}"),
+            ));
         }
         filter.result = Some(value.clone());
     }
diff --git a/src/query/report_stream.rs b/src/query/report_stream.rs
index 27df24d..deef72c 100644
--- a/src/query/report_stream.rs
+++ b/src/query/report_stream.rs
@@ -772,8 +772,7 @@ fn process_raw_publication_point(
                 let after_cursor = pp_index > state.start_pp_index
                     || (pp_index == state.start_pp_index
                         && object_index >= state.start_object_index);
-                if after_cursor && state.data.len() < state.limit && state.filter.matches(&record)
-                {
+                if after_cursor && state.data.len() < state.limit && state.filter.matches(&record) {
                     state.data.push(record);
                     if state.data.len() == state.limit {
                         state.next_cursor = Some(object_cursor(pp_index, object_index + 1));