| 63 | dev::forward_ready!(service); |
| 64 | |
| 65 | fn call(&self, req: ServiceRequest) -> Self::Future { |
| 66 | let svc = self.service.clone(); |
| 67 | |
| 68 | Box::pin(async move { |
| 69 | let headers = req.headers(); |
| 70 | let _ = match headers.get("Authorization") { |
| 71 | Some(e) => e, |
| 72 | None => { |
| 73 | let new_response = HttpResponseBuilder::new(StatusCode::BAD_REQUEST) |
| 74 | .insert_header((header::CONTENT_TYPE, "application/json")) |
| 75 | .json(HttpData::default()); |
| 76 | return Ok(ServiceResponse::new( |
| 77 | req.request().to_owned(), /* or req.request().clone() */ |
| 78 | new_response, |
| 79 | )); |
| 80 | } |
| 81 | }; |
| 82 | |
| 83 | let res = svc.call(req).await?; |
| 84 | Ok(res) |
| 85 | }) |
| 86 | } |
| 87 | } |