// Copyright 2015-2018 Parity Technologies (UK) Ltd. // This file is part of Parity. // Parity is free software: you can redistribute it and/or modify // it under the terms of the GNU General Public License as published by // the Free Software Foundation, either version 3 of the License, or // (at your option) any later version. // Parity is distributed in the hope that it will be useful, // but WITHOUT ANY WARRANTY; without even the implied warranty of // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the // GNU General Public License for more details. // You should have received a copy of the GNU General Public License // along with Parity. If not, see . pub mod client; pub mod signer_client; extern crate futures; extern crate jsonrpc_core; extern crate jsonrpc_ws_server as ws; extern crate parity_rpc as rpc; extern crate parking_lot; extern crate serde; extern crate serde_json; extern crate url; extern crate keccak_hash as hash; #[macro_use] extern crate log; #[cfg(test)] #[macro_use] extern crate matches; /// Boxed future response. pub type BoxFuture = Box + Send>; #[cfg(test)] mod tests { use futures::Future; use std::path::PathBuf; use client::{Rpc, RpcError}; use rpc; #[test] fn test_connection_refused() { let (_srv, port, mut authcodes) = rpc::tests::ws::serve(); let _ = authcodes.generate_new(); authcodes.to_file(&authcodes.path).unwrap(); let connect = Rpc::connect(&format!("ws://127.0.0.1:{}", port - 1), &authcodes.path); let _ = connect.map(|conn| { assert!(matches!(&conn, &Err(RpcError::WsError(_)))); }).wait(); } #[test] fn test_authcode_fail() { let (_srv, port, _) = rpc::tests::ws::serve(); let path = PathBuf::from("nonexist"); let connect = Rpc::connect(&format!("ws://127.0.0.1:{}", port), &path); let _ = connect.map(|conn| { assert!(matches!(&conn, &Err(RpcError::NoAuthCode))); }).wait(); } #[test] fn test_authcode_correct() { let (_srv, port, mut authcodes) = rpc::tests::ws::serve(); let _ = authcodes.generate_new(); authcodes.to_file(&authcodes.path).unwrap(); let connect = Rpc::connect(&format!("ws://127.0.0.1:{}", port), &authcodes.path); let _ = connect.map(|conn| { assert!(conn.is_ok()) }).wait(); } }