1 files changed, 55 insertions, 0 deletions
diff --git a/src/client.rs b/src/client.rs
new file mode 100644
index 0000000..5328a2d
--- /dev/null
+++ b/src/client.rs
@@ -0,0 +1,55 @@
+use futures::Stream;
+use futures::future::Future;
+use hyper::Uri;
+use hyper::client::{Client, HttpConnector};
+use hyper::error::UriError;
+use response::{self, Error};
+use serde_json;
+use tokio_core::reactor::Handle;
+
+
+pub type AsyncResponse<T> = Box<Future<Item = T, Error = Error>>;
+
+
+pub struct IpfsClient {
+    base: Uri,
+    client: Client<HttpConnector>,
+}
+
+impl IpfsClient {
+    /// Creates a new `IpfsClient`.
+    ///
+    #[inline]
+    pub fn new(handle: &Handle, host: &str, port: u16) -> Result<IpfsClient, UriError> {
+        let base_path = IpfsClient::build_base_path(host, port)?;
+
+        Ok(IpfsClient {
+            base: base_path,
+            client: Client::new(handle),
+        })
+    }
+
+    /// Builds the base uri path for the Ipfs API.
+    ///
+    fn build_base_path(host: &str, port: u16) -> Result<Uri, UriError> {
+        format!("http://{}:{}/api/v0", host, port).parse()
+    }
+}
+
+impl IpfsClient {
+    /// Returns information about the Ipfs server version.
+    ///
+    pub fn version(&self) -> AsyncResponse<response::VersionResponse> {
+        let uri = format!("{}/version", self.base).parse().unwrap();
+
+        Box::new(
+            self.client
+                .get(uri)
+                .and_then(|res| res.body().concat2())
+                .from_err()
+                .and_then(move |body| {
+                    serde_json::from_slice(&body).map_err(From::from)
+                }),
+        )
+    }
+}