pcvolkmer/bwhc-kafka-proxy
1
0
Fork 0
mirror of https://github.com/CCC-MF/bwhc-kafka-rest-proxy.git synced 2025-04-19 19:16:51 +00:00
Code Issues Activity

feat: do not use episode id in kafka record key

Browse Source 
Closes #1
This commit is contained in:
Paul-Christian Volkmer 2024-03-09 11:24:09 +01:00
parent 6d6eccb36e
commit a32f1522f9
2 changed files with 4 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/auth.rs
View File

@ -1,5 +1,5 @@
use base64::Engine;
use base64::prelude::BASE64_STANDARD; use base64::prelude::BASE64_STANDARD;
use base64::Engine;
pub fn check_basic_auth(auth_header: &str, expected_token: &str) -> bool { pub fn check_basic_auth(auth_header: &str, expected_token: &str) -> bool {
let split = auth_header.split(' ').collect::<Vec<_>>(); let split = auth_header.split(' ').collect::<Vec<_>>();

13
src/main.rs
View File

@ -1,18 +1,18 @@
use std::env; use std::env;
use std::time::Duration; use std::time::Duration;
use axum::{Extension, Json, Router};
use axum::body::Body; use axum::body::Body;
use axum::extract::Path; use axum::extract::Path;
use axum::http::{Request, StatusCode};
use axum::http::header::AUTHORIZATION; use axum::http::header::AUTHORIZATION;
use axum::http::{Request, StatusCode};
use axum::middleware::{from_fn, Next}; use axum::middleware::{from_fn, Next};
use axum::response::Response; use axum::response::Response;
use axum::routing::{delete, post}; use axum::routing::{delete, post};
use axum::{Extension, Json, Router};
use bwhc_dto::MtbFile; use bwhc_dto::MtbFile;
use rdkafka::ClientConfig;
use rdkafka::message::{Header, OwnedHeaders}; use rdkafka::message::{Header, OwnedHeaders};
use rdkafka::producer::{FutureProducer, FutureRecord}; use rdkafka::producer::{FutureProducer, FutureRecord};
use rdkafka::ClientConfig;
use serde::{Deserialize, Serialize}; use serde::{Deserialize, Serialize};
#[cfg(debug_assertions)] #[cfg(debug_assertions)]
use tower_http::trace::TraceLayer; use tower_http::trace::TraceLayer;
@ -24,8 +24,6 @@ mod auth;
struct RecordKey { struct RecordKey {
#[serde(rename = "pid")] #[serde(rename = "pid")]
patient_id: String, patient_id: String,
#[serde(rename = "eid", skip_serializing_if = "Option::is_none")]
episode_id: Option<String>,
} }
#[tokio::main] #[tokio::main]
@ -103,11 +101,6 @@ async fn send_mtb_file(
let record_key = RecordKey { let record_key = RecordKey {
patient_id: mtb_file.patient.id.to_string(), patient_id: mtb_file.patient.id.to_string(),
episode_id: if mtb_file.episode.id.is_empty() {
None
} else {
Some(mtb_file.episode.id.to_string())
},
}; };
let record_headers = OwnedHeaders::default().insert(Header { let record_headers = OwnedHeaders::default().insert(Header {