Add a feature to ignore empty path segments (// in path).

Cargo.toml

@@ -58,6 +58,9 @@ default = ["multipart", "websocket"]
 websocket = ["tokio-tungstenite"]
 tls = ["tokio-rustls"]
 
+# allow double slashes in paths
+ignore-empty-path-segments = []
+
 # Enable compression-related filters
 compression = ["compression-brotli", "compression-gzip"]
 compression-brotli = ["async-compression/brotli"]
@@ -79,6 +82,10 @@ required-features = ["multipart"]
 name = "ws"
 required-features = ["websocket"]
 
+[[test]]
+name = "path_empty_segments"
+required-features = ["ignore-empty-path-segments"]
+
 [[example]]
 name = "compression"
 required-features = ["compression"]

examples/todos.rs

@@ -38,7 +38,7 @@ mod filters {
     /// The 4 TODOs filters combined.
     pub fn todos(
         db: Db,
-    ) -> impl Filter<Extract = impl warp::Reply, Error = warp::Rejection> + Clone {
+    ) -> impl Filter<Extract = (impl warp::Reply,), Error = warp::Rejection> + Clone {
         todos_list(db.clone())
             .or(todos_create(db.clone()))
             .or(todos_update(db.clone()))
@@ -48,7 +48,7 @@ mod filters {
     /// GET /todos?offset=3&limit=5
     pub fn todos_list(
         db: Db,
-    ) -> impl Filter<Extract = impl warp::Reply, Error = warp::Rejection> + Clone {
+    ) -> impl Filter<Extract = (impl warp::Reply,), Error = warp::Rejection> + Clone {
         warp::path!("todos")
             .and(warp::get())
             .and(warp::query::<ListOptions>())
@@ -59,7 +59,7 @@ mod filters {
     /// POST /todos with JSON body
     pub fn todos_create(
         db: Db,
-    ) -> impl Filter<Extract = impl warp::Reply, Error = warp::Rejection> + Clone {
+    ) -> impl Filter<Extract = (impl warp::Reply,), Error = warp::Rejection> + Clone {
         warp::path!("todos")
             .and(warp::post())
             .and(json_body())
@@ -70,7 +70,7 @@ mod filters {
     /// PUT /todos/:id with JSON body
     pub fn todos_update(
         db: Db,
-    ) -> impl Filter<Extract = impl warp::Reply, Error = warp::Rejection> + Clone {
+    ) -> impl Filter<Extract = (impl warp::Reply,), Error = warp::Rejection> + Clone {
         warp::path!("todos" / u64)
             .and(warp::put())
             .and(json_body())
@@ -81,7 +81,7 @@ mod filters {
     /// DELETE /todos/:id
     pub fn todos_delete(
         db: Db,
-    ) -> impl Filter<Extract = impl warp::Reply, Error = warp::Rejection> + Clone {
+    ) -> impl Filter<Extract = (impl warp::Reply,), Error = warp::Rejection> + Clone {
         // We'll make one of our endpoints admin-only to show how authentication filters are used
         let admin_only = warp::header::exact("authorization", "Bearer admin");
 

src/filters/path.rs

@@ -371,6 +371,7 @@ impl Peek {
 
     /// Get an iterator over the segments of the peeked path.
     pub fn segments(&self) -> impl Iterator<Item = &str> {
+        // NOTE: this ignores empty segments regardless of feature settings
         self.as_str().split('/').filter(|seg| !seg.is_empty())
     }
 }

src/route.rs

@@ -43,12 +43,17 @@ enum BodyState {
 
 impl Route {
     pub(crate) fn new(req: Request, remote_addr: Option<SocketAddr>) -> RefCell<Route> {
-        let segments_index = if req.uri().path().starts_with('/') {
-            // Skip the beginning slash.
-            1
-        } else {
-            0
-        };
+        let mut segments_index: usize = 0;
+        if req.uri().path().starts_with('/') {
+            segments_index += 1;
+            #[cfg(feature = "ignore-empty-path-segments")]
+            {
+                let path = req.uri().path().as_bytes();
+                while segments_index < path.len() && path[segments_index] == b'/' {
+                    segments_index += 1;
+                }
+            }
+        }
 
         RefCell::new(Route {
             body: BodyState::Ready,
@@ -93,15 +98,19 @@ impl Route {
 
     pub(crate) fn set_unmatched_path(&mut self, index: usize) {
         let index = self.segments_index + index;
-        let path = self.req.uri().path();
+        let path = self.req.uri().path().as_bytes();
         if path.is_empty() {
             // malformed path
             return;
         } else if path.len() == index {
             self.segments_index = index;
         } else {
-            debug_assert_eq!(path.as_bytes()[index], b'/');
+            debug_assert_eq!(path[index], b'/');
             self.segments_index = index + 1;
+            #[cfg(feature = "ignore-empty-path-segments")]
+            while self.segments_index < path.len() && path[self.segments_index] == b'/' {
+                self.segments_index += 1;
+            }
         }
     }