diff options
| -rw-r--r-- | examples/README.md | 3 | ||||
| -rw-r--r-- | examples/eventsource/README.md | 22 | ||||
| -rw-r--r-- | examples/eventsource/priv/index.html | 44 | ||||
| -rw-r--r-- | examples/eventsource/rebar.config | 6 | ||||
| -rw-r--r-- | examples/eventsource/src/eventsource.app.src | 15 | ||||
| -rw-r--r-- | examples/eventsource/src/eventsource.erl | 14 | ||||
| -rw-r--r-- | examples/eventsource/src/eventsource_app.erl | 30 | ||||
| -rw-r--r-- | examples/eventsource/src/eventsource_handler.erl | 27 | ||||
| -rw-r--r-- | examples/eventsource/src/eventsource_sup.erl | 23 | ||||
| -rwxr-xr-x | examples/eventsource/start.sh | 3 |
10 files changed, 187 insertions, 0 deletions
diff --git a/examples/README.md b/examples/README.md index e166876..109d156 100644 --- a/examples/README.md +++ b/examples/README.md @@ -22,6 +22,9 @@ Cowboy Examples * [elixir_hello_world](./elixir_hello_world): simplest example application with Elixir + * [eventsource](./eventsource): + eventsource emitter and consumer + * [hello_world](./hello_world): simplest example application diff --git a/examples/eventsource/README.md b/examples/eventsource/README.md new file mode 100644 index 0000000..c9662a1 --- /dev/null +++ b/examples/eventsource/README.md @@ -0,0 +1,22 @@ +Cowboy EventSource +================== + +To compile this example you need rebar in your PATH. + +Type the following command: +``` +$ rebar get-deps compile +``` + +You can then start the Erlang node with the following command: +``` +./start.sh +``` + +Uses Cowboy's loop functionality to continuously send events to the browser. + +Example +------- + +Point your browser to http://localhost:8080 to see EventSource in action with +any modern browser (not IE). diff --git a/examples/eventsource/priv/index.html b/examples/eventsource/priv/index.html new file mode 100644 index 0000000..f057195 --- /dev/null +++ b/examples/eventsource/priv/index.html @@ -0,0 +1,44 @@ +<!DOCTYPE html> +<html> + <head> + <script type="text/javascript"> + function ready() { + if (!!window.EventSource) { + setupEventSource(); + } else { + document.getElementById('status').innerHTML = + "Sorry but your browser doesn't support the EventSource API"; + } + } + + function setupEventSource() { + var source = new EventSource('/eventsource'); + + source.addEventListener('message', function(event) { + addStatus("server sent the following: '" + event.data + "'"); + }, false); + + source.addEventListener('open', function(event) { + addStatus('eventsource connected.') + }, false); + + source.addEventListener('error', function(event) { + if (event.eventPhase == EventSource.CLOSED) { + addStatus('eventsource was closed.') + } + }, false); + } + + function addStatus(text) { + var date = new Date(); + document.getElementById('status').innerHTML + = document.getElementById('status').innerHTML + + date + ": " + text + "<br/>"; + } + </script> + </head> + <body onload="ready();"> + Hi! + <div id="status"></div> + </body> +</html> diff --git a/examples/eventsource/rebar.config b/examples/eventsource/rebar.config new file mode 100644 index 0000000..eb6f194 --- /dev/null +++ b/examples/eventsource/rebar.config @@ -0,0 +1,6 @@ +{deps, [ + {cowboy, ".*", + {git, "git://github.com/extend/cowboy.git", "master"}}, + {mimetypes, ".*", + {git, "git://github.com/spawngrid/mimetypes.git", "master"}} +]}. diff --git a/examples/eventsource/src/eventsource.app.src b/examples/eventsource/src/eventsource.app.src new file mode 100644 index 0000000..002ea85 --- /dev/null +++ b/examples/eventsource/src/eventsource.app.src @@ -0,0 +1,15 @@ +%% Feel free to use, reuse and abuse the code in this file. + +{application, eventsource, [ + {description, "Cowboy EventSource example."}, + {vsn, "1"}, + {modules, []}, + {registered, []}, + {applications, [ + kernel, + stdlib, + cowboy + ]}, + {mod, {eventsource_app, []}}, + {env, []} +]}. diff --git a/examples/eventsource/src/eventsource.erl b/examples/eventsource/src/eventsource.erl new file mode 100644 index 0000000..6505e62 --- /dev/null +++ b/examples/eventsource/src/eventsource.erl @@ -0,0 +1,14 @@ +%% Feel free to use, reuse and abuse the code in this file. + +-module(eventsource). + +%% API. +-export([start/0]). + +%% API. + +start() -> + ok = application:start(crypto), + ok = application:start(ranch), + ok = application:start(cowboy), + ok = application:start(eventsource). diff --git a/examples/eventsource/src/eventsource_app.erl b/examples/eventsource/src/eventsource_app.erl new file mode 100644 index 0000000..d002676 --- /dev/null +++ b/examples/eventsource/src/eventsource_app.erl @@ -0,0 +1,30 @@ +%% Feel free to use, reuse and abuse the code in this file. + +%% @private +-module(eventsource_app). +-behaviour(application). + +%% API. +-export([start/2]). +-export([stop/1]). + +%% API. + +start(_Type, _Args) -> + Dispatch = cowboy_router:compile([ + {'_', [ + {"/eventsource", eventsource_handler, []}, + {"/", cowboy_static, [ + {directory, {priv_dir, eventsource, []}}, + {file, <<"index.html">>}, + {mimetypes, {fun mimetypes:path_to_mimes/2, default}} + ]} + ]} + ]), + {ok, _} = cowboy:start_http(http, 100, [{port, 8080}], [ + {env, [{dispatch, Dispatch}]} + ]), + eventsource_sup:start_link(). + +stop(_State) -> + ok. diff --git a/examples/eventsource/src/eventsource_handler.erl b/examples/eventsource/src/eventsource_handler.erl new file mode 100644 index 0000000..661057c --- /dev/null +++ b/examples/eventsource/src/eventsource_handler.erl @@ -0,0 +1,27 @@ +%% Feel free to use, reuse and abuse the code in this file. + +%% @doc EventSource emitter. +-module(eventsource_handler). + +-export([init/3]). +-export([info/3]). +-export([terminate/3]). + +init(_Transport, Req, []) -> + Headers = [{<<"content-type">>, <<"text/event-stream">>}], + {ok, Req2} = cowboy_req:chunked_reply(200, Headers, Req), + erlang:send_after(1000, self(), {message, "Tick"}), + {loop, Req2, undefined, 5000}. + +info({message, Msg}, Req, State) -> + ok = cowboy_req:chunk(["id: ", id(), "\ndata: ", Msg, "\n\n"], Req), + erlang:send_after(1000, self(), {message, "Tick"}), + {loop, Req, State}. + +terminate(_Reason, _Req, _State) -> + ok. + +id() -> + {Mega, Sec, Micro} = erlang:now(), + Id = (Mega * 1000000 + Sec) * 1000000 + Micro, + integer_to_list(Id, 16). diff --git a/examples/eventsource/src/eventsource_sup.erl b/examples/eventsource/src/eventsource_sup.erl new file mode 100644 index 0000000..611b015 --- /dev/null +++ b/examples/eventsource/src/eventsource_sup.erl @@ -0,0 +1,23 @@ +%% Feel free to use, reuse and abuse the code in this file. + +%% @private +-module(eventsource_sup). +-behaviour(supervisor). + +%% API. +-export([start_link/0]). + +%% supervisor. +-export([init/1]). + +%% API. + +-spec start_link() -> {ok, pid()}. +start_link() -> + supervisor:start_link({local, ?MODULE}, ?MODULE, []). + +%% supervisor. + +init([]) -> + Procs = [], + {ok, {{one_for_one, 10, 10}, Procs}}. diff --git a/examples/eventsource/start.sh b/examples/eventsource/start.sh new file mode 100755 index 0000000..e97398f --- /dev/null +++ b/examples/eventsource/start.sh @@ -0,0 +1,3 @@ +#!/bin/sh +erl -pa ebin deps/*/ebin -s eventsource \ + -eval "io:format(\"Point your browser at http://localhost:8080/~n\")." |