json request example

examples/json/Cargo.toml

@@ -0,0 +1,16 @@
+[package]
+name = "json-example"
+version = "0.1.0"
+authors = ["Nikolay Kim <fafhrd91@gmail.com>"]
+
+[dependencies]
+bytes = "0.4"
+futures = "0.1"
+env_logger = "*"
+
+serde = "1.0"
+serde_json = "1.0"
+serde_derive = "1.0"
+
+actix = "^0.3.1"
+actix-web = { git = "https://github.com/actix/actix-web.git" }

examples/json/client.py

@@ -0,0 +1,17 @@
+# This script could be used for actix-web multipart example test
+# just start server and run client.py
+
+import json
+import asyncio
+import aiohttp
+
+async def req():
+    resp = await aiohttp.ClientSession().request(
+        "post", 'http://localhost:8080/',
+        data=json.dumps({"name": "Test user", "number": 100}),
+        headers={"content-type": "application/json"})
+    print(str(resp))
+    assert 200 == resp.status
+
+
+asyncio.get_event_loop().run_until_complete(req())

examples/json/src/main.rs

@@ -0,0 +1,64 @@
+extern crate actix;
+extern crate actix_web;
+extern crate bytes;
+extern crate futures;
+extern crate env_logger;
+extern crate serde_json;
+#[macro_use] extern crate serde_derive;
+
+use actix_web::*;
+use bytes::BytesMut;
+use futures::Stream;
+use futures::future::{Future, ok, err, result};
+
+#[derive(Debug, Deserialize)]
+struct MyObj {
+    name: String,
+    number: i32,
+}
+
+fn index(mut req: HttpRequest) -> Result<Box<Future<Item=HttpResponse, Error=Error>>> {
+    // check content-type, early error exit
+    if req.content_type() != "application/json" {
+        return Err(error::ErrorBadRequest("wrong content-type").into())
+    }
+
+    Ok(Box::new(
+        // load request body
+        req.payload_mut()
+            .readany()
+            .fold(BytesMut::new(), |mut body, chunk| {
+                body.extend(chunk);
+                result::<_, error::PayloadError>(Ok(body))
+            })
+            .map_err(|e| Error::from(e))
+            .and_then(|body| {
+                // body is loaded, now we can deserialize json
+                match serde_json::from_slice::<MyObj>(&body) {
+                    Ok(obj) => {
+                        println!("MODEL: {:?}", obj);    // <- do something with payload
+                        ok(httpcodes::HTTPOk.response()) // <- send response
+                    },
+                    Err(e) => {
+                        err(error::ErrorBadRequest(e).into())
+                    }
+                }
+            })))
+}
+
+fn main() {
+    ::std::env::set_var("RUST_LOG", "actix_web=info");
+    let _ = env_logger::init();
+    let sys = actix::System::new("json-example");
+
+    HttpServer::new(|| {
+        Application::new()
+            // enable logger
+            .middleware(middlewares::Logger::default())
+            .resource("/", |r| r.method(Method::POST).f(index))})
+        .bind("127.0.0.1:8080").unwrap()
+        .start();
+
+    println!("Started http server: 127.0.0.1:8080");
+    let _ = sys.run();
+}