Moved main into a test in lib.rs

src/macros/src/lib.rs

@@ -91,3 +91,47 @@ macro_rules! rpc_service {
         }
     }
 }
+
+#[cfg(test)]
+mod test {
+    use std::net::{TcpListener, TcpStream};
+    use std::thread;
+
+    #[derive(PartialEq, Debug, RustcEncodable, RustcDecodable)]
+    pub struct Foo {
+        message: String
+    }
+
+    rpc_service!(my_server:
+        hello(super::Foo) -> super::Foo;
+        add((i32, i32)) -> i32;
+    );
+
+    //use my_server::*;
+
+    impl my_server::Service for () {
+        fn hello(&self, s: Foo) -> Foo {
+            Foo{message: format!("Hello, {}", &s.message)}
+        }
+
+        fn add(&self, (x, y): (i32, i32)) -> i32 {
+            x + y
+        }
+    }
+
+    #[test]
+    fn simple_test() {
+        println!("Starting");
+        let listener = TcpListener::bind("127.0.0.1:9000").unwrap();
+        thread::spawn(|| {
+            let server = my_server::Server::new(());
+            println!("Server running");
+            server.serve(listener);
+        });
+        let mut client = my_server::Client(TcpStream::connect("127.0.0.1:9000").unwrap());
+        assert_eq!(3, client.add((1, 2)).unwrap());
+        let foo = Foo{message: "Adam".into()};
+        let want = Foo{message: format!("Hello, {}", &foo.message)};
+        assert_eq!(want, client.hello(Foo{message: "Adam".into()}).unwrap());
+    }
+}

src/macros/src/main.rs

@@ -1,42 +0,0 @@
-#[macro_use]
-extern crate macros;
-extern crate rustc_serialize;
-extern crate byteorder;
-
-use std::net::{TcpListener, TcpStream};
-
-#[derive(Debug, RustcEncodable, RustcDecodable)]
-pub struct Foo {
-    message: String
-}
-
-rpc_service!(my_server:
-    hello(::Foo) -> ::Foo;
-    add((i32, i32)) -> i32;
-);
-
-use my_server::*;
-
-impl Service for () {
-    fn hello(&self, s: Foo) -> Foo {
-        Foo{message: format!("Hello, {}", &s.message)}
-    }
-    
-    fn add(&self, (x, y): (i32, i32)) -> i32 {
-        x + y
-    }
-}
-
-fn main() {
-    println!("Starting");
-    let listener = TcpListener::bind("127.0.0.1:9000").unwrap();
-    std::thread::spawn(|| {
-        let server = Server::new(());
-        println!("Server running");
-        server.serve(listener);
-    });
-    let mut client = Client(TcpStream::connect("127.0.0.1:9000").unwrap());
-    println!("Client running");
-    println!("add((1, 2)) => {}", client.add((1, 2)).unwrap());
-    println!("hello(\"adam\") => {:?}", client.hello(Foo{message: "Adam".into()}));
-}