Hyper Websocket

As much as I do like Rust I have to admit there are some disadvantages of using this language – one common problem is immaturity and fragmentation of libraries –  I encountered this recently when I was looking for a way how create a websocket endpoint for audioserve.  audioserve is using low level HTTP library hyper – as it’s API is quite simple (which was it’s key design principle). I wanted to add websocket support on lowest possible level.  Actually it turned out as not totally trivial –  some frameworks like warp or actix have build in websocket support, but for pure hyper + websocket we have to start from bottom. 

Recent Hyper has a nice support for HTTP connection upgrade – as can be seen in this example.  This was good start, but I needed to plug in there some websocket library in a compatible ( and hopefully easy) way.  And here some problems pop up.  Looking into crates.io, you can find several libraries, first on top was crate called plainly websocket – it’s fairly popular and advertises hyper integration, but  alas with version 0.10, which is already fairly outdated, new hyper 0.12 is much different.  Another popular crate is ws, but there is nothing there about integration with hyper, so it would require a deep dive into the library to find useful parts. There are also couple of other libraries – two derivatives of already mention  websocket crate and some others.  Does not seem to be easy to choose right one.  So I had to look around –  the already mentioned warp framework is supporting both web sockets and hyper and it’s created by maintainer of hyper Sean McArthur – so I hoped I could find right solution there.   And yes,  Sean is using yet another websocket crate called tungstenite, which advertise itself as lightweight, easy to integrate library.   So I looked into warp code and find necessary parts and  extracted them into separate module, just as an exercise to understand how it works.  If you need just websocket in hyper look at code below:

 

With provided code it’s then fairly easy – in hyper service  use upgrade_connection function, which consumes request and returns tuple (response, future).  Response is to be sent immediately back(it’s either successful 101 protocol upgrade or 400 error in case of websocket handshake problem), future then resolves to WebSocket structure, which implements Stream and Sink of websocket messages.

Leave a Reply

Your email address will not be published. Required fields are marked *

You may use these HTML tags and attributes: <a href="" title=""> <abbr title=""> <acronym title=""> <b> <blockquote cite=""> <cite> <code class="" title="" data-url=""> <del datetime=""> <em> <i> <q cite=""> <s> <strike> <strong> <pre class="" title="" data-url=""> <span class="" title="" data-url="">