mirror of https://github.com/fafhrd91/actix-web
fix(awc): some methods incorrectly send body & body-headers
This commit is contained in:
parent
aceff9d13f
commit
612e983576
|
@ -2,6 +2,8 @@
|
||||||
|
|
||||||
## Unreleased
|
## Unreleased
|
||||||
|
|
||||||
|
- `GET/HEAD/OPTIONS/TRACE` methods no longer send a request body on request.
|
||||||
|
|
||||||
## 3.7.0
|
## 3.7.0
|
||||||
|
|
||||||
- Update `brotli` dependency to `8`.
|
- Update `brotli` dependency to `8`.
|
||||||
|
|
|
@ -4,8 +4,12 @@ use std::{
|
||||||
task::{Context, Poll},
|
task::{Context, Poll},
|
||||||
};
|
};
|
||||||
|
|
||||||
use actix_http::body::{BodySize, BoxBody, MessageBody};
|
use actix_http::{
|
||||||
|
body::{BodySize, BoxBody, MessageBody},
|
||||||
|
RequestHead,
|
||||||
|
};
|
||||||
use bytes::Bytes;
|
use bytes::Bytes;
|
||||||
|
use http::Method;
|
||||||
use pin_project_lite::pin_project;
|
use pin_project_lite::pin_project;
|
||||||
|
|
||||||
pin_project! {
|
pin_project! {
|
||||||
|
@ -75,11 +79,15 @@ where
|
||||||
/// Converts a [`MessageBody`] type into the best possible representation.
|
/// Converts a [`MessageBody`] type into the best possible representation.
|
||||||
///
|
///
|
||||||
/// Checks size for `None` and tries to convert to `Bytes`. Otherwise, uses the `Body` variant.
|
/// Checks size for `None` and tries to convert to `Bytes`. Otherwise, uses the `Body` variant.
|
||||||
pub fn from_message_body(body: B) -> Self
|
pub fn from_message_body(head: &RequestHead, body: B) -> Self
|
||||||
where
|
where
|
||||||
B: MessageBody,
|
B: MessageBody,
|
||||||
{
|
{
|
||||||
if matches!(body.size(), BodySize::None) {
|
if matches!(
|
||||||
|
head.method,
|
||||||
|
Method::GET | Method::HEAD | Method::OPTIONS | Method::TRACE
|
||||||
|
) || matches!(body.size(), BodySize::None)
|
||||||
|
{
|
||||||
return Self::None;
|
return Self::None;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
@ -189,16 +189,14 @@ impl RequestSender {
|
||||||
body: impl MessageBody + 'static,
|
body: impl MessageBody + 'static,
|
||||||
) -> SendClientRequest {
|
) -> SendClientRequest {
|
||||||
let req = match self {
|
let req = match self {
|
||||||
RequestSender::Owned(head) => ConnectRequest::Client(
|
RequestSender::Owned(head) => {
|
||||||
RequestHeadType::Owned(head),
|
let body = AnyBody::from_message_body(&head, body).into_boxed();
|
||||||
AnyBody::from_message_body(body).into_boxed(),
|
ConnectRequest::Client(RequestHeadType::Owned(head), body, addr)
|
||||||
addr,
|
}
|
||||||
),
|
RequestSender::Rc(head, extra_headers) => {
|
||||||
RequestSender::Rc(head, extra_headers) => ConnectRequest::Client(
|
let body = AnyBody::from_message_body(&head, body).into_boxed();
|
||||||
RequestHeadType::Rc(head, extra_headers),
|
ConnectRequest::Client(RequestHeadType::Rc(head, extra_headers), body, addr)
|
||||||
AnyBody::from_message_body(body).into_boxed(),
|
}
|
||||||
addr,
|
|
||||||
),
|
|
||||||
};
|
};
|
||||||
|
|
||||||
let fut = config.connector.call(req);
|
let fut = config.connector.call(req);
|
||||||
|
|
Loading…
Reference in New Issue