diff options
author | Ferris Tseng <ferristseng@fastmail.fm> | 2017-11-19 21:07:41 -0500 |
---|---|---|
committer | Ferris Tseng <ferristseng@fastmail.fm> | 2017-11-19 21:07:41 -0500 |
commit | 1bb1691f617d7a2114150a4de382868b689d6dd8 (patch) | |
tree | 0b3767c36f214ca3fb91e04444d4b5dce191257b | |
parent | b62e1711acc654ee1eb60eadb953adc6d4005749 (diff) |
add a fake ipfs server that just prints out requests
-rw-r--r-- | ipfs-api/examples/server.rs | 58 |
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(); +} |