package websocket-lwt-unix
Websocket library (Lwt)
Install
Dune Dependency
Authors
Maintainers
Sources
websocket-lwt-unix-2.15.tbz
sha256=7ba435572227093515e60fa58c395735750d16d0ca866a7dbc0986d2f67f55bc
sha512=b7d939035d86300fba6dee1d7b59f85f0255827fd8aef2cdabfe9f9185cf84020ba07c7835d4c54ced9b21a2b974cc626aed921f11de5ed81c40d1cfa0f4fd48
doc/src/websocket-lwt-unix.cohttp/websocket_cohttp_lwt.ml.html
Source file websocket_cohttp_lwt.ml
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
(* * Copyright (c) 2016-2018 Maciej Wos <maciej.wos@gmail.com> * Copyright (c) 2012-2018 Vincent Bernardoff <vb@luminar.eu.org> * * Permission to use, copy, modify, and distribute this software for any * purpose with or without fee is hereby granted, provided that the above * copyright notice and this permission notice appear in all copies. * * THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES * WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF * MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR * ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES * WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN * ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF * OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE. * *) open Lwt.Infix open Websocket module Lwt_IO = Websocket.Make (Cohttp_lwt_unix.IO) let send_frames stream oc = let buf = Buffer.create 128 in let send_frame fr = Buffer.clear buf ; Lwt_IO.write_frame_to_buf ~mode:Server buf fr ; Lwt_io.write oc @@ Buffer.contents buf in Lwt_stream.iter_s send_frame stream let read_frames ic oc handler_fn = let read_frame = Lwt_IO.make_read_frame ~mode:Server ic oc in let rec inner () = read_frame () >>= Lwt.wrap1 handler_fn >>= inner in inner () let upgrade_connection request incoming_handler = let headers = Cohttp.Request.headers request in ( match Cohttp.Header.get headers "sec-websocket-key" with | None -> Lwt.fail_invalid_arg "upgrade_connection: missing header `sec-websocket-key`" | Some key -> Lwt.return key ) >>= fun key -> let hash = b64_encoded_sha1sum (key ^ websocket_uuid) in let response_headers = Cohttp.Header.of_list [ ("Upgrade", "websocket"); ("Connection", "Upgrade"); ("Sec-WebSocket-Accept", hash) ] in let resp = Cohttp.Response.make ~status:`Switching_protocols ~encoding:Cohttp.Transfer.Unknown ~headers:response_headers ~flush:true () in let frames_out_stream, frames_out_fn = Lwt_stream.create () in let f ic oc = Lwt.pick [ (* input: data from the client is read from the input channel * of the tcp connection; pass it to handler function *) read_frames ic oc incoming_handler; (* output: data for the client is written to the output * channel of the tcp connection *) send_frames frames_out_stream oc ] in Lwt.return (`Expert (resp, f), frames_out_fn)
sectionYPositions = computeSectionYPositions($el), 10)"
x-init="setTimeout(() => sectionYPositions = computeSectionYPositions($el), 10)"
>