actix-form-data 0.7.0-rc.3

Multipart Form Data for Actix Web
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56

use actix_form_data::{Error, Field, Form, FormData, Multipart, Value};
use actix_web::{
    web::{post, resource},
    App, HttpRequest, HttpResponse, HttpServer,
};
use futures_util::stream::StreamExt;

struct UploadedContent(Value<()>);

impl FormData for UploadedContent {
    type Item = ();
    type Error = Error;

    fn form(_: &HttpRequest) -> Result<Form<Self::Item, Self::Error>, Self::Error> {
        Ok(Form::new()
            .field("Hey", Field::text())
            .field(
                "Hi",
                Field::map()
                    .field("One", Field::int())
                    .field("Two", Field::float())
                    .finalize(),
            )
            .field(
                "files",
                Field::array(Field::file(async move |_, _, mut stream| {
                    while let Some(res) = stream.next().await {
                        res?;
                    }
                    Ok(()) as Result<(), Error>
                })),
            ))
    }

    fn extract(value: Value<Self::Item>) -> Result<Self, Self::Error>
    where
        Self: Sized,
    {
        Ok(UploadedContent(value))
    }
}

async fn upload(Multipart(UploadedContent(value)): Multipart<UploadedContent>) -> HttpResponse {
    println!("Uploaded Content: {:#?}", value);
    HttpResponse::Created().finish()
}

#[actix_rt::main]
async fn main() -> Result<(), anyhow::Error> {
    HttpServer::new(move || App::new().service(resource("/upload").route(post().to(upload))))
        .bind("127.0.0.1:8080")?
        .run()
        .await?;

    Ok(())
}