1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92
#![allow(unused)] extern crate websocket_base; use futures::future::Future; use futures::stream::Stream; use std::cell::RefCell; use std::rc::Rc; use super::{box_up_err, peer_err, peer_strerr, BoxedNewPeerFuture, Peer, Result}; use super::ws_peer::{Mode1, PeerForWs, WsReadWrapper, WsWriteWrapper}; use super::{once, ConstructParams, Options, PeerConstructor, Specifier}; use self::websocket_base::codec::ws::Context as WsLlContext; #[derive(Debug, Clone)] pub struct WsLlClient<T: Specifier>(pub T); impl<T:Specifier> Specifier for WsLlClient<T> { fn construct(&self, p: ConstructParams) -> PeerConstructor { let inner = self.0.construct(p.clone()); let opts = p.program_options; inner.map(move |q, _| get_ws_lowlevel_peer( WsLlContext::Client, q, opts.clone(), )) } specifier_boilerplate!(noglobalstate singleconnect has_subspec); } specifier_class!( name = WsLlClientClass, target = WsLlClient, prefixes = ["ws-lowlevel-client:","ws-ll-client:","ws-ll-c:"], arg_handling = subspec, overlay = false, MessageOriented, SingleConnect, help = r#" [A] Low-level HTTP-independent WebSocket client connection without associated HTTP upgrade. Example: TODO "# ); #[derive(Debug, Clone)] pub struct WsLlServer<T: Specifier>(pub T); impl<T:Specifier> Specifier for WsLlServer<T> { fn construct(&self, p: ConstructParams) -> PeerConstructor { let inner = self.0.construct(p.clone()); let opts = p.program_options; inner.map(move |q, _| get_ws_lowlevel_peer( WsLlContext::Server, q, opts.clone(), )) } specifier_boilerplate!(noglobalstate singleconnect has_subspec); } specifier_class!( name = WsLlServerClass, target = WsLlServer, prefixes = ["ws-lowlevel-server:","ws-ll-server:","ws-ll-s:"], arg_handling = subspec, overlay = false, MessageOriented, SingleConnect, help = r#" [A] Low-level HTTP-independent WebSocket server connection without associated HTTP upgrade. Example: TODO "# ); pub fn get_ws_lowlevel_peer(mode: WsLlContext, mut inner: Peer, opts: Rc<Options>) -> BoxedNewPeerFuture { info!("get_ws_lowlevel_peer"); use ::tokio_codec::Decoder; let c = websocket_base::codec::ws::MessageCodec::new(mode); let hup = inner.2; inner.2 = None; let duplex = c.framed(PeerForWs(inner)); let close_on_shutdown = !opts.websocket_dont_close; let p = super::ws_peer::finish_building_ws_peer(&*opts, duplex, close_on_shutdown, hup); Box::new( ::futures::future::ok(p) ) as BoxedNewPeerFuture }