diff --git a/.env.example b/.env.example index c9b70b6..cc7db71 100644 --- a/.env.example +++ b/.env.example @@ -1 +1,6 @@ -REDIS_URL=redis://localhost \ No newline at end of file +REDIS_URL=redis://localhost +# REDIS_HOST=localhost +# REDIS_PORT=6379 +# REDIS_USERNAME=default +# REDIS_USE_TLS=true +# REDIS_PASSWORD= \ No newline at end of file diff --git a/src/routes/request.rs b/src/routes/request.rs index d444b6a..0a10787 100644 --- a/src/routes/request.rs +++ b/src/routes/request.rs @@ -73,10 +73,17 @@ async fn get_request( .await .map_err(handle_redis_error)?; - serde_json::from_slice(&value.unwrap()) - .map_or(Err(StatusCode::INTERNAL_SERVER_ERROR), |value| { + serde_json::from_slice(&value.unwrap()).map_or( + Err(StatusCode::INTERNAL_SERVER_ERROR), + |value| { + tracing::info!( + "{}", + format!("Successfully retrieved /request: {request_id}") + ); + Ok(Json(value)) - }) + }, + ) } async fn insert_request( @@ -107,10 +114,7 @@ async fn insert_request( .await .map_err(handle_redis_error)?; - tracing::info!( - "{}", - format!("Successfully processed /request: {request_id}") - ); + tracing::info!("{}", format!("Successfully stored /request: {request_id}")); Ok(Json(CustomResponse { request_id })) } diff --git a/src/routes/response.rs b/src/routes/response.rs index d825ae2..3688569 100644 --- a/src/routes/response.rs +++ b/src/routes/response.rs @@ -49,6 +49,10 @@ async fn get_response( return serde_json::from_slice(&value).map_or( Err(StatusCode::INTERNAL_SERVER_ERROR), |value| { + tracing::info!( + "{}", + format!("Successfully retrieved /response: {request_id}") + ); Ok(Json(Response { response: value, status: RequestStatus::Completed, @@ -118,5 +122,7 @@ async fn insert_response( .await .map_err(handle_redis_error)?; + tracing::info!("{}", format!("Successfully stored /response: {request_id}")); + Ok(StatusCode::CREATED) }