[go: up one dir, main page]

civet 0.1.11

civetweb-based server implementation for conduit
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
57
58
59
60
61

#![feature(io)]

extern crate civet;
extern crate conduit;

use std::collections::HashMap;
use std::error::Error;
use std::old_io::{IoResult, MemReader, MemWriter};
use std::sync::mpsc::channel;

use civet::{Config, Server, response};
use conduit::{Request, Response};

macro_rules! http_write {
    ($dst:expr, $fmt:expr) => (
        try!(write!(&mut $dst, concat!($fmt, "\r\n")))
    );
    ($dst:expr, $fmt:expr, $($arg:tt)*) => (
        try!(write!(&mut $dst, concat!($fmt, "\r\n"), $($arg)*))
    )
}

fn main() {
    let _a = Server::start(Config { port: 8888, threads: 50 },
                           |&: a: &mut Request| {
        handler(a).map_err(|e| Box::new(e) as Box<Error+Send>)
    });
    let (_tx, rx) = channel::<()>();
    rx.recv().unwrap();
}

fn handler(req: &mut Request) -> IoResult<Response> {
    let mut res = MemWriter::with_capacity(10000);

    http_write!(res, "<style>body {{ font-family: sans-serif; }}</style>");
    http_write!(res, "<p>HTTP {}</p>", req.http_version());
    http_write!(res, "<p>Method: {:?}</p>", req.method());
    http_write!(res, "<p>Scheme: {:?}</p>", req.scheme());
    http_write!(res, "<p>Host: {:?}</p>", req.host());
    http_write!(res, "<p>Path: {}</p>", req.path());
    http_write!(res, "<p>Query String: {:?}</p>", req.query_string());
    http_write!(res, "<p>Remote IP: {}</p>", req.remote_ip());
    http_write!(res, "<p>Content Length: {:?}</p>", req.content_length());

    http_write!(res, "<p>Input: {}", req.body().read_to_string().unwrap());

    http_write!(res, "<h2>Headers</h2><ul>");

    // for (key, value) in req.headers().iter() {
    //     http_write!(res, "<li>{} = {}</li>", key, value);
    // }

    http_write!(res, "</ul>");

    let mut headers = HashMap::new();
    headers.insert("Content-Type".to_string(), vec!("text/html".to_string()));

    let body = MemReader::new(res.into_inner());

    Ok(response(200, headers, body))
}