From 370da2778879b4cb143ce38880468f4265c0ba84 Mon Sep 17 00:00:00 2001 From: Paul-Christian Volkmer Date: Sun, 7 Sep 2025 11:42:57 +0200 Subject: [PATCH] feat: do not accept records without request ID --- README.md | 3 ++- src/main.rs | 5 ++++- 2 files changed, 6 insertions(+), 2 deletions(-) diff --git a/README.md b/README.md index b0b165f..9ab7af7 100644 --- a/README.md +++ b/README.md @@ -68,7 +68,8 @@ Kafka-Records müssen eine(n) * **Key** im JSON-Format mit einem Wert für `patientID` haben. * **Header** mit Wert für`requestId` haben, damit eine ordnungsgemäße Zuordnung zu einer Anfrage im **mv64e-etl-processor** stattfinden kann. - Ist dies nicht gegeben, kann die Rückantwort nicht einer eingehenden Anfrage zugeordnet werden. + Ist dies nicht gegeben, kann die Rückantwort nicht einer eingehenden Anfrage zugeordnet werden. + Anfragen ohne `requestId` im Header werden abgelehnt. * **Payload** haben, die dem DNPM-Datenmodell 2.1 entspricht. Eine Prüfung auf MV- oder Forschungs-Consent findet nicht statt. diff --git a/src/main.rs b/src/main.rs index 4a8bc38..b342024 100644 --- a/src/main.rs +++ b/src/main.rs @@ -151,7 +151,10 @@ async fn main() -> Result<(), Box> { continue; }; - let request_id = extract_request_id(&msg).unwrap_or_default(); + let Some(request_id) = extract_request_id(&msg) else { + error!("Error getting request_id"); + continue; + }; match handle_record(payload).await { Err(err) => error!("{}", err),