// Copyright 2015, 2016 Ethcore (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 . //! `WebSockets` server. use ws; use std; use std::thread; use std::ops::Drop; use std::sync::Arc; use std::sync::atomic::{AtomicUsize, Ordering}; use std::net::SocketAddr; use util::panics::{PanicHandler, OnPanicListener, MayPanic}; /// Signer startup error #[derive(Debug)] pub enum ServerError { /// Wrapped `std::io::Error` IoError(std::io::Error), /// Other `ws-rs` error Other(ws::Error) } impl From for ServerError { fn from(err: ws::Error) -> Self { match err.kind { ws::ErrorKind::Io(e) => ServerError::IoError(e), _ => ServerError::Other(err), } } } /// `WebSockets` server implementation. pub struct Server { handle: Option>>, broadcaster: ws::Sender, panic_handler: Arc, } impl Server { /// Starts a new `WebSocket` server in separate thread. /// Returns a `Server` handle which closes the server when droped. pub fn start(addr: SocketAddr) -> Result { let config = { let mut config = ws::Settings::default(); config.max_connections = 5; config.method_strict = true; config }; // Create WebSocket let session_id = Arc::new(AtomicUsize::new(1)); let ws = try!(ws::Builder::new().with_settings(config).build(Factory { session_id: session_id, })); let panic_handler = PanicHandler::new_in_arc(); let ph = panic_handler.clone(); let broadcaster = ws.broadcaster(); // Spawn a thread with event loop let handle = thread::spawn(move || { ph.catch_panic(move || { ws.listen(addr).unwrap() }).unwrap() }); // Return a handle Ok(Server { handle: Some(handle), broadcaster: broadcaster, panic_handler: panic_handler, }) } } impl MayPanic for Server { fn on_panic(&self, closure: F) where F: OnPanicListener { self.panic_handler.on_panic(closure); } } impl Drop for Server { fn drop(&mut self) { self.broadcaster.shutdown().expect("WsServer should close nicely."); self.handle.take().unwrap().join().unwrap(); } } struct Session { id: usize, out: ws::Sender, } impl ws::Handler for Session { fn on_open(&mut self, _shake: ws::Handshake) -> ws::Result<()> { try!(self.out.send(format!("Hello client no: {}. We are not implemented yet.", self.id))); try!(self.out.close(ws::CloseCode::Normal)); Ok(()) } } struct Factory { session_id: Arc, } impl ws::Factory for Factory { type Handler = Session; fn connection_made(&mut self, sender: ws::Sender) -> Self::Handler { Session { id: self.session_id.fetch_add(1, Ordering::SeqCst), out: sender, } } }