m-j-w/server_sent_events.jl

## server_sent_events.jl
# Example adapted from https://www.html5rocks.com/en/tutorials/eventsource/basics/WebSockets.jl
using HttpServer

hdr = Dict{AbstractString,AbstractString}(
            [ "Content-Type"  => "text/event-stream"
            , "Cache-Control" => "no-cache"
            , "Connection"    => "keep-alive" ] )

idx = raw"""
<html><body><h1>Getting server updates</h1><div id="result"></div><script>
if(typeof(EventSource) !== "undefined") {
    var source = new EventSource("/push/");
    source.onmessage = function(event) {
        document.getElementById("result").innerHTML += event.data + "<br>";
    };
} else {
    document.getElementById("result").innerHTML = "Sorry, your browser does not support server-sent events...";
}
</script></body></html>
"""

http = HttpHandler() do req::Request, res::Response
    if ismatch(r"^/push/", req.resource)
        println("Serving Push...")
        Response( 200, hdr,
                 #"event: update\n" *  # Give this event a name to be filtered
                                       # or handled accordingly on the client side
                 #"id: myid\n" *       # Give this update a unique id, e.g.  from local time
                 #"retry: 10000\n" *   # Retry reconnect every 10s = 10_000 ms
                 "data: The server time is: $(now())\n\n" )
    else
        println("Serving Index...")
        Response(idx)
    end
end

http.events["error"]   = (client, err) -> println(err)
http.events["listen"]  = (port)        -> println("Listening on $port...")
http.events["connect"] = (client)      -> println("$(client.id) connected.")
http.events["close"]   = (client)      -> println("$(client.id) closed.")

server = Server(http)
try
   host = IPv4(127,0,0,1)
   run(server, host=host, port=1234)
catch e
   println('\n',e,'\n')
end
close(server)
	# Example adapted from https://www.html5rocks.com/en/tutorials/eventsource/basics/WebSockets.jl
	using HttpServer

	hdr = Dict{AbstractString,AbstractString}(
	[ "Content-Type" => "text/event-stream"
	, "Cache-Control" => "no-cache"
	, "Connection" => "keep-alive" ] )

	idx = raw"""
	<html><body><h1>Getting server updates</h1><div id="result"></div><script>
	if(typeof(EventSource) !== "undefined") {
	var source = new EventSource("/push/");
	source.onmessage = function(event) {
	document.getElementById("result").innerHTML += event.data + "<br>";
	};
	} else {
	document.getElementById("result").innerHTML = "Sorry, your browser does not support server-sent events...";
	}
	</script></body></html>
	"""

	http = HttpHandler() do req::Request, res::Response
	if ismatch(r"^/push/", req.resource)
	println("Serving Push...")
	Response( 200, hdr,
	#"event: update\n" * # Give this event a name to be filtered
	# or handled accordingly on the client side
	#"id: myid\n" * # Give this update a unique id, e.g. from local time
	#"retry: 10000\n" * # Retry reconnect every 10s = 10_000 ms
	"data: The server time is: $(now())\n\n" )
	else
	println("Serving Index...")
	Response(idx)
	end
	end

	http.events["error"] = (client, err) -> println(err)
	http.events["listen"] = (port) -> println("Listening on $port...")
	http.events["connect"] = (client) -> println("$(client.id) connected.")
	http.events["close"] = (client) -> println("$(client.id) closed.")

	server = Server(http)
	try
	host = IPv4(127,0,0,1)
	run(server, host=host, port=1234)
	catch e
	println('\n',e,'\n')
	end
	close(server)