Add implementation

Author: rousan

.github/workflows/test.yml

@@ -0,0 +1,16 @@
+name: Test
+
+on:
+  push:
+    branches: [master, develop]
+  pull_request:
+    branches: [master, develop]
+
+jobs:
+  build:
+    runs-on: ubuntu-latest
+
+    steps:
+      - uses: actions/checkout@v2
+      - name: Run tests
+        run: cargo test --verbose

.gitignore

@@ -0,0 +1,49 @@
+# Created by https://www.gitignore.io/api/rust,macos
+# Edit at https://www.gitignore.io/?templates=rust,macos
+
+### macOS ###
+# General
+.DS_Store
+.AppleDouble
+.LSOverride
+
+# Icon must end with two \r
+Icon
+
+# Thumbnails
+._*
+
+# Files that might appear in the root of a volume
+.DocumentRevisions-V100
+.fseventsd
+.Spotlight-V100
+.TemporaryItems
+.Trashes
+.VolumeIcon.icns
+.com.apple.timemachine.donotpresent
+
+# Directories potentially created on remote AFP share
+.AppleDB
+.AppleDesktop
+Network Trash Folder
+Temporary Items
+.apdisk
+
+### Rust ###
+# Generated by Cargo
+# will have compiled files and executables
+/target/
+
+# Remove Cargo.lock from gitignore if creating an executable, leave it for libraries
+# More information here https://doc.rust-lang.org/cargo/guide/cargo-toml-vs-cargo-lock.html
+Cargo.lock
+
+# These are backup files generated by rustfmt
+**/*.rs.bk
+
+### Others ###
+.halt.releez.yml
+routerify-multipart.iml
+/.idea
+
+# End of https://www.gitignore.io/api/rust,macos

Cargo.toml

@@ -0,0 +1,31 @@
+[package]
+name = "routerify-multipart"
+version = "1.0.0"
+description = "A multipart/form-data parser for Routerify."
+homepage = "https://github.com/routerify/routerify-multipart"
+repository = "https://github.com/routerify/routerify-multipart"
+keywords = ["routerify", "hyper-rs", "hyper", "multipart", "multipart-formdata"]
+categories = ["asynchronous", "web-programming", "web-programming::http-server"]
+authors = ["Rousan Ali <[email protected]>"]
+readme = "README.md"
+license = "MIT"
+edition = "2018"
+
+[package.metadata.docs.rs]
+all-features = true
+
+[package.metadata.playground]
+features = ["all"]
+
+[features]
+default = []
+all = ["json"]
+json = ["multer/json"]
+
+[dependencies]
+routerify = "1.1"
+hyper = "0.13"
+multer = "1.0"
+
+[dev-dependencies]
+tokio = { version = "0.2", features = ["full"] }

LICENSE

@@ -0,0 +1,21 @@
+MIT License
+
+Copyright (c) 2020 Rousan Ali
+
+Permission is hereby granted, free of charge, to any person obtaining a copy
+of this software and associated documentation files (the "Software"), to deal
+in the Software without restriction, including without limitation the rights
+to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
+copies of the Software, and to permit persons to whom the Software is
+furnished to do so, subject to the following conditions:
+
+The above copyright notice and this permission notice shall be included in all
+copies or substantial portions of the Software.
+
+THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
+AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
+OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
+SOFTWARE.

README.md

@@ -1,2 +1,91 @@
+[![Github Actions Status](https://github.com/routerify/routerify-multipart/workflows/Test/badge.svg)](https://github.com/routerify/routerify-multipart/actions)
+[![crates.io](https://img.shields.io/crates/v/routerify-multipart.svg)](https://crates.io/crates/routerify-multipart)
+[![Documentation](https://docs.rs/routerify-multipart/badge.svg)](https://docs.rs/routerify-multipart)
+[![MIT](https://img.shields.io/crates/l/routerify-multipart.svg)](./LICENSE)
+
 # routerify-multipart
-A multipart/form-data parser for Routerify
+
+A `multipart/form-data` parser for [`Routerify`](https://github.com/routerify/routerify).
+
+[Docs](https://docs.rs/routerify-multipart)
+
+## Install
+
+Add this to your `Cargo.toml` file:
+
+```toml
+[dependencies]
+routerify = "1.1"
+routerify-multipart = "1.0"
+```
+
+## Example
+
+```rust
+use hyper::{Body, Request, Response, Server, StatusCode};
+use routerify::{Error, Router, RouterService};
+// Import `RequestMultipartExt` trait.
+use routerify_multipart::RequestMultipartExt;
+use std::net::SocketAddr;
+
+// A handler to handle file uploading in `multipart/form-data` content-type.
+async fn file_upload_handler(req: Request<Body>) -> Result<Response<Body>, Error> {
+    // Convert the request into a `Multipart` instance.
+    let mut multipart = match req.into_multipart() {
+        Ok(m) => m,
+        Err(err) => {
+            return Ok(Response::builder()
+                .status(StatusCode::BAD_REQUEST)
+                .body(Body::from(format!("Bad Request: {}", err)))
+                .unwrap());
+        }
+    };
+
+    // Iterate over the fields.
+    while let Some(mut field) = multipart.next_field().await.map_err(|err| Error::wrap(err))? {
+        // Get the field name.
+        let name = field.name();
+        // Get the field's filename if provided in "Content-Disposition" header.
+        let file_name = field.file_name();
+
+        println!("Name {:?}, File name: {:?}", name, file_name);
+
+        // Process the field data chunks e.g. store them in a file.
+        while let Some(chunk) = field.chunk().await.map_err(|err| Error::wrap(err))? {
+            // Do something with field chunk.
+            println!("Chunk: {:?}", chunk);
+        }
+    }
+
+    Ok(Response::new(Body::from("Success")))
+}
+
+// Create a router.
+fn router() -> Router<Body, Error> {
+    // Register the handlers.
+    Router::builder().post("/upload", file_upload_handler).build().unwrap()
+}
+
+#[tokio::main]
+async fn main() {
+    let router = router();
+
+    // Create a Service from the router above to handle incoming requests.
+    let service = RouterService::new(router).unwrap();
+
+    // The address on which the server will be listening.
+    let addr = SocketAddr::from(([127, 0, 0, 1], 3001));
+
+    // Create a server by passing the created service to `.serve` method.
+    let server = Server::bind(&addr).serve(service);
+
+    println!("App is running on: {}", addr);
+    if let Err(err) = server.await {
+        eprintln!("Server error: {}", err);
+    }
+}
+```
+
+## Contributing
+
+Your PRs and suggestions are always welcome.

examples/example.rs

@@ -0,0 +1,62 @@
+use hyper::{Body, Request, Response, Server, StatusCode};
+use routerify::{Error, Router, RouterService};
+// Import `RequestMultipartExt` trait.
+use routerify_multipart::RequestMultipartExt;
+use std::net::SocketAddr;
+
+// A handler to handle file uploading in `multipart/form-data` content-type.
+async fn file_upload_handler(req: Request<Body>) -> Result<Response<Body>, Error> {
+    // Convert the request into a `Multipart` instance.
+    let mut multipart = match req.into_multipart() {
+        Ok(m) => m,
+        Err(err) => {
+            return Ok(Response::builder()
+                .status(StatusCode::BAD_REQUEST)
+                .body(Body::from(format!("Bad Request: {}", err)))
+                .unwrap());
+        }
+    };
+
+    // Iterate over the fields.
+    while let Some(mut field) = multipart.next_field().await.map_err(|err| Error::wrap(err))? {
+        // Get the field name.
+        let name = field.name();
+        // Get the field's filename if provided in "Content-Disposition" header.
+        let file_name = field.file_name();
+
+        println!("Name {:?}, File name: {:?}", name, file_name);
+
+        // Process the field data chunks e.g. store them in a file.
+        while let Some(chunk) = field.chunk().await.map_err(|err| Error::wrap(err))? {
+            // Do something with field chunk.
+            println!("Chunk: {:?}", chunk);
+        }
+    }
+
+    Ok(Response::new(Body::from("Success")))
+}
+
+// Create a router.
+fn router() -> Router<Body, Error> {
+    // Register the handlers.
+    Router::builder().post("/upload", file_upload_handler).build().unwrap()
+}
+
+#[tokio::main]
+async fn main() {
+    let router = router();
+
+    // Create a Service from the router above to handle incoming requests.
+    let service = RouterService::new(router).unwrap();
+
+    // The address on which the server will be listening.
+    let addr = SocketAddr::from(([127, 0, 0, 1], 3001));
+
+    // Create a server by passing the created service to `.serve` method.
+    let server = Server::bind(&addr).serve(service);
+
+    println!("App is running on: {}", addr);
+    if let Err(err) = server.await {
+        eprintln!("Server error: {}", err);
+    }
+}

examples/test.rs

@@ -0,0 +1,43 @@
+use hyper::{Body, Request, Response, Server};
+use routerify::{Error, Router, RouterService};
+use routerify_multipart::RequestMultipartExt;
+use std::net::SocketAddr;
+
+async fn file_upload_handler(req: Request<Body>) -> Result<Response<Body>, Error> {
+    let mut multipart = req.into_multipart().map_err(|err| Error::wrap(err))?;
+
+    while let Some(field) = multipart.next_field().await.map_err(|err| Error::wrap(err))? {
+        let name = field.name();
+        let file_name = field.file_name();
+
+        println!("Name {:?}, File name: {:?}", name, file_name);
+
+        let content = field.text().await.map_err(|err| Error::wrap(err))?;
+        println!("Content {:?}", content);
+    }
+
+    Ok(Response::new(Body::from("Success")))
+}
+
+fn router() -> Router<Body, Error> {
+    Router::builder().post("/upload", file_upload_handler).build().unwrap()
+}
+
+#[tokio::main]
+async fn main() {
+    let router = router();
+
+    // Create a Service from the router above to handle incoming requests.
+    let service = RouterService::new(router).unwrap();
+
+    // The address on which the server will be listening.
+    let addr = SocketAddr::from(([127, 0, 0, 1], 3001));
+
+    // Create a server by passing the created service to `.serve` method.
+    let server = Server::bind(&addr).serve(service);
+
+    println!("App is running on: {}", addr);
+    if let Err(err) = server.await {
+        eprintln!("Server error: {}", err);
+    }
+}

releez.yml

@@ -0,0 +1,53 @@
+version: 1.0.0
+checklist:
+  - name: Checkout develop and sync with remote
+    type: auto
+    run:
+      - git checkout develop
+      - git push
+  - name: Check syntax
+    type: auto
+    run:
+      - cargo check --release --features="all"
+  - name: Run tests
+    type: auto
+    run:
+      - cargo test --release --features="all"
+  - name: Start a new release branch
+    type: auto
+    run:
+      - git flow release start "v${VERSION}"
+  - name: Make sure code is formatted
+    type: auto
+    run:
+      - cargo fmt
+  - name: Bump version
+    type: manual
+    instructions:
+      - Please update version with ${VERSION} in Cargo.toml file.
+      - Please update version with ${VERSION} in README.md file if needed.
+  - name: Commit changes
+    type: auto
+    run:
+      - git add --all && git commit -m "Bump version"
+  - name: Finish release branch
+    type: auto
+    run:
+      - git flow release finish -s "v${VERSION}"
+  - name: Push branches and tags to Github
+    type: auto
+    run:
+      - git checkout master
+      - git push origin master
+      - git push origin develop
+      - git push --tags
+  - name: Edit tag on Github
+    type: manual
+    instructions:
+      - Tag is pushed to Github(https://github.com/routerify/routerify-multipart/releases). Edit it there and make it a release.
+  - name: Publish to crates.io
+    type: auto
+    confirm: Are you sure to publish it to crates.io?
+    run:
+      - cargo publish
+      - git checkout develop

rustfmt.toml

@@ -0,0 +1,2 @@
+max_width = 120
+tab_spaces = 4