Merge 9ea97a676a into d119500f93

Cargo.lock

@@ -345,7 +345,7 @@ dependencies = [
 
 [[package]]
 name = "actix-web"
-version = "4.11.0"
+version = "4.12.0"
 dependencies = [
  "actix-codec",
  "actix-files",

actix-http/CHANGES.md

@@ -2,6 +2,10 @@
 
 ## Unreleased
 
+## 3.11.3
+
+- Update `HttpMessage`s `content_type` method to return `Option<&str>` instead of `&str`.
+
 ## 3.11.2
 
 - Properly wake Payload receivers when feeding errors or EOF.

actix-http/src/http_message.rs

@@ -46,13 +46,11 @@ pub trait HttpMessage: Sized {
 
     /// Read the request content type. If request did not contain a *Content-Type* header, an empty
     /// string is returned.
-    fn content_type(&self) -> &str {
-        if let Some(content_type) = self.headers().get(header::CONTENT_TYPE) {
-            if let Ok(content_type) = content_type.to_str() {
-                return content_type.split(';').next().unwrap().trim();
-            }
-        }
-        ""
+    fn content_type(&self) -> Option<&str> {
+        self.headers()
+            .get(header::CONTENT_TYPE)
+            .and_then(|ct| ct.to_str().ok())
+            .map(|ct| ct.split(';').next().unwrap().trim())
     }
 
     /// Get content type encoding.
@@ -142,13 +140,13 @@ mod tests {
         let req = TestRequest::default()
             .insert_header(("content-type", "text/plain"))
             .finish();
-        assert_eq!(req.content_type(), "text/plain");
+        assert_eq!(req.content_type(), Some("text/plain"));
         let req = TestRequest::default()
             .insert_header(("content-type", "application/json; charset=utf-8"))
             .finish();
-        assert_eq!(req.content_type(), "application/json");
+        assert_eq!(req.content_type(), Some("application/json"));
         let req = TestRequest::default().finish();
-        assert_eq!(req.content_type(), "");
+        assert_eq!(req.content_type(), None);
     }
 
     #[test]

actix-web/CHANGES.md

@@ -2,8 +2,10 @@
 
 ## Unreleased
 
+## 4.12.0
+
 - `actix_web::response::builder::HttpResponseBuilder::streaming()` now sets `Content-Type` to `application/octet-stream` if `Content-Type` does not exist.
-- `actix_web::response::builder::HttpResponseBuilder::streaming()` now calls `actix_web::response::builder::HttpResponseBuilder::no_chunking()` if `Content-Length` is set by user.
+- `actix_web::response::builder::HttpResponseBuilder::streaming()` now calls `actix_web::response::builder::HttpResponseBuilder::no_chunking()` and returns `SizedStream` if `Content-Length` is set by user.
 - Add `ws` crate feature (on-by-default) which forwards to `actix-http` and guards some of its `ResponseError` impls.
 - Add public export for `EitherExtractError` in `error` module.
 

actix-web/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "actix-web"
-version = "4.11.0"
+version = "4.12.0"
 description = "Actix Web is a powerful, pragmatic, and extremely fast web framework for Rust"
 authors = ["Nikolay Kim <fafhrd91@gmail.com>", "Rob Ede <robjtede@icloud.com>"]
 keywords = ["actix", "http", "web", "framework", "async"]

actix-web/README.md

@@ -8,10 +8,10 @@
 <!-- prettier-ignore-start -->
 
 [![crates.io](https://img.shields.io/crates/v/actix-web?label=latest)](https://crates.io/crates/actix-web)
-[![Documentation](https://docs.rs/actix-web/badge.svg?version=4.11.0)](https://docs.rs/actix-web/4.11.0)
+[![Documentation](https://docs.rs/actix-web/badge.svg?version=4.12.0)](https://docs.rs/actix-web/4.12.0)
 ![MSRV](https://img.shields.io/badge/rustc-1.72+-ab6000.svg)
 ![MIT or Apache 2.0 licensed](https://img.shields.io/crates/l/actix-web.svg)
-[![Dependency Status](https://deps.rs/crate/actix-web/4.11.0/status.svg)](https://deps.rs/crate/actix-web/4.11.0)
+[![Dependency Status](https://deps.rs/crate/actix-web/4.12.0/status.svg)](https://deps.rs/crate/actix-web/4.12.0)
 <br />
 [![CI](https://github.com/actix/actix-web/actions/workflows/ci.yml/badge.svg)](https://github.com/actix/actix-web/actions/workflows/ci.yml)
 [![codecov](https://codecov.io/gh/actix/actix-web/graph/badge.svg?token=dSwOnp9QCv)](https://codecov.io/gh/actix/actix-web)

actix-web/src/response/builder.rs

@@ -11,7 +11,7 @@ use futures_core::Stream;
 use serde::Serialize;
 
 use crate::{
-    body::{BodyStream, BoxBody, MessageBody},
+    body::{BodyStream, BoxBody, MessageBody, SizedStream},
     dev::Extensions,
     error::{Error, JsonPayloadError},
     http::{
@@ -335,18 +335,19 @@ impl HttpResponseBuilder {
             }
         }
 
-        if let Some(parts) = self.inner() {
-            if let Some(length) = parts.headers.get(header::CONTENT_LENGTH) {
-                if let Ok(length) = length.to_str() {
-                    if let Ok(length) = length.parse::<u64>() {
-                        self.no_chunking(length);
-                    }
-                }
-            }
-        }
+        let content_length = self
+            .inner()
+            .and_then(|parts| parts.headers.get(header::CONTENT_LENGTH))
+            .and_then(|value| value.to_str().ok())
+            .and_then(|value| value.parse::<u64>().ok());
 
+        if let Some(len) = content_length {
+            self.no_chunking(len);
+            self.body(SizedStream::new(len, stream))
+        } else {
             self.body(BodyStream::new(stream))
         }
+    }
 
     /// Set a JSON body and build the `HttpResponse`.
     ///

actix-web/src/test/test_utils.rs

@@ -505,7 +505,10 @@ mod tests {
             .set_form(&payload)
             .to_request();
 
-        assert_eq!(req.content_type(), "application/x-www-form-urlencoded");
+        assert_eq!(
+            req.content_type().unwrap(),
+            "application/x-www-form-urlencoded"
+        );
 
         let result: Person = call_and_read_body_json(&app, req).await;
         assert_eq!(&result.id, "12345");
@@ -549,7 +552,7 @@ mod tests {
             .set_json(&payload)
             .to_request();
 
-        assert_eq!(req.content_type(), "application/json");
+        assert_eq!(req.content_type(), Some("application/json"));
 
         let result: Person = call_and_read_body_json(&app, req).await;
         assert_eq!(&result.id, "12345");

actix-web/src/types/form.rs

@@ -289,14 +289,17 @@ impl<T> UrlEncoded<T> {
     /// Create a new future to decode a URL encoded request payload.
     pub fn new(req: &HttpRequest, payload: &mut Payload) -> Self {
         // check content type
-        if req.content_type().to_lowercase() != "application/x-www-form-urlencoded" {
+        let encoding_error = req
+            .content_type()
+            .map(|ct| !ct.eq_ignore_ascii_case("application/x-www-form-urlencoded"))
+            .unwrap_or(true);
+        if encoding_error {
             return Self::err(UrlencodedError::ContentType);
         }
         let encoding = match req.encoding() {
             Ok(enc) => enc,
             Err(_) => return Self::err(UrlencodedError::ContentType),
         };
-
         let mut len = None;
         if let Some(l) = req.headers().get(&CONTENT_LENGTH) {
             if let Ok(s) = l.to_str() {