use actix_web::body::MessageBody;
use actix_web::dev::{ServiceRequest, ServiceResponse};
use actix_web::middleware::Next;
use actix_web::HttpMessage;
use actix_request_identifier::RequestId;
pub async fn request_id(
req: ServiceRequest,
next: Next<impl MessageBody>,
) -> Result<ServiceResponse<impl MessageBody>, actix_web::Error> {
if let Some(request_id) = req.extensions().get::<RequestId>() {
log_mdc::insert("request_id", request_id.as_str().to_string());
}
next.call(req).await
}