Initial commit

Author: wycats

.gitignore

@@ -0,0 +1 @@
+/target/

Cargo.toml

@@ -0,0 +1,26 @@
+[package]
+
+name = "conduit-static"
+version = "0.5.0"
+authors = ["[email protected]"]
+
+[[lib]]
+
+name = "conduit-static"
+
+[[bin]]
+
+name = "simple-file-server"
+path = "examples/simple-file-server.rs"
+
+[dependencies.civet]
+
+git = "https://github.com/wycats/rust-civet.git"
+
+[dependencies.conduit]
+
+git = "https://github.com/conduit-rust/conduit.git"
+
+[dependencies.conduit-test]
+
+git = "https://github.com/conduit-rust/conduit-test.git"

examples/simple-file-server.rs

@@ -0,0 +1,35 @@
+extern crate green;
+extern crate rustuv;
+
+extern crate civet;
+extern crate conduit;
+extern crate conduit_static = "conduit-static";
+
+use std::os;
+
+use civet::{Config, Server};
+use conduit_static::Static;
+
+fn main() {
+    let handler = Static::new(os::getcwd());
+    let _a = Server::start(Config { port: 8888, threads: 50 }, handler);
+
+    wait_for_sigint();
+}
+
+fn wait_for_sigint() {
+    use green::{SchedPool, PoolConfig, GreenTaskBuilder};
+    use std::io::signal::{Listener, Interrupt};
+    use std::task::TaskBuilder;
+
+    let mut config = PoolConfig::new();
+    config.event_loop_factory = rustuv::event_loop;
+
+    let mut pool = SchedPool::new(config);
+    TaskBuilder::new().green(&mut pool).spawn(proc() {
+        let mut l = Listener::new();
+        l.register(Interrupt).unwrap();
+        l.rx.recv();
+    });
+    pool.shutdown();
+}

src/conduit-static.rs

@@ -0,0 +1,58 @@
+extern crate conduit;
+
+use std::fmt::Show;
+use std::collections::HashMap;
+use std::io::fs::File;
+use std::io::util::NullReader;
+use conduit::{Request, Response, Handler};
+
+pub struct Static {
+    path: Path
+}
+
+impl Static {
+    pub fn new(path: Path) -> Static {
+        Static { path: path }
+    }
+}
+
+impl Handler for Static {
+    fn call(&self, request: &mut Request) -> Result<Response, Box<Show>> {
+        let request_path = request.path().slice_from(1);
+        let path = self.path.join(request_path);
+
+        if !self.path.is_ancestor_of(&path) {
+            return Ok(Response {
+                status: (404, "Not Found"),
+                headers: HashMap::new(),
+                body: box NullReader
+            })
+        }
+
+        let file = try!(File::open(&path).map_err(|e| box e as Box<Show>));
+
+        Ok(Response {
+            status: (200, "OK"),
+            headers: HashMap::new(),
+            body: box file as Box<Reader + Send>
+        })
+    }
+}
+
+#[cfg(test)]
+mod tests {
+    extern crate test = "conduit-test";
+    use conduit;
+    use conduit::Handler;
+    use Static;
+
+    #[test]
+    fn test_static() {
+        let root = Path::new(file!()).dir_path().dir_path();
+        let handler = Static::new(root);
+        let mut req = test::MockRequest::new(conduit::Get, "/Cargo.toml");
+        let mut res = handler.call(&mut req).ok().expect("No response");
+        let body = res.body.read_to_str().ok().expect("No body");
+        assert!(body.as_slice().contains("[package]"), "The Cargo.toml was provided");
+    }
+}