add a fake ipfs server that just prints out requests

1 files changed, 58 insertions, 0 deletions

diff --git a/ipfs-api/examples/server.rs b/ipfs-api/examples/server.rs
new file mode 100644
index 0000000..bc02c90
--- /dev/null
+++ b/ipfs-api/examples/server.rs
@@ -0,0 +1,58 @@
+// Copyright 2017 rust-ipfs-api Developers
+//
+// Licensed under the Apache License, Version 2.0, <LICENSE-APACHE or
+// http://apache.org/licenses/LICENSE-2.0> or the MIT license <LICENSE-MIT or
+// http://opensource.org/licenses/MIT>, at your option. This file may not be
+// copied, modified, or distributed except according to those terms.
+//
+
+extern crate futures;
+extern crate hyper;
+
+use futures::future::Future;
+use futures::stream::Stream;
+use hyper::StatusCode;
+use hyper::server::{Http, Service, Request, Response};
+
+struct Debug;
+
+impl Service for Debug {
+    type Request = Request;
+
+    type Response = Response;
+
+    type Error = hyper::Error;
+
+    type Future = Box<Future<Item = Response, Error = hyper::Error>>;
+
+
+    fn call(&self, req: Request) -> Self::Future {
+        println!("{:?}", req);
+
+        let res = req.body().concat2().map(|bod| {
+            println!("{}", String::from_utf8_lossy(&bod));
+
+            Response::new().with_status(StatusCode::Ok)
+        });
+
+        Box::new(res)
+    }
+}
+
+
+/// This example runs a server on the default Ipfs port. All it does is
+/// print requests as it gets them. It is useful for debugging.
+///
+fn main() {
+    let addr = "127.0.0.1:5001".parse().unwrap();
+    let mut server = Http::new().bind(&addr, || Ok(Debug)).unwrap();
+
+    server.no_proto();
+
+    println!(
+        "Listening on http://{} with 1 thread.",
+        server.local_addr().unwrap()
+    );
+
+    server.run().unwrap();
+}