aboutsummaryrefslogtreecommitdiff
path: root/server/_build/default/lib/cowlib/src/cow_sse.erl
diff options
context:
space:
mode:
Diffstat (limited to 'server/_build/default/lib/cowlib/src/cow_sse.erl')
-rw-r--r--server/_build/default/lib/cowlib/src/cow_sse.erl349
1 files changed, 349 insertions, 0 deletions
diff --git a/server/_build/default/lib/cowlib/src/cow_sse.erl b/server/_build/default/lib/cowlib/src/cow_sse.erl
new file mode 100644
index 0000000..6e7081f
--- /dev/null
+++ b/server/_build/default/lib/cowlib/src/cow_sse.erl
@@ -0,0 +1,349 @@
+%% Copyright (c) 2017-2023, Loïc Hoguin <essen@ninenines.eu>
+%%
+%% Permission to use, copy, modify, and/or 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.
+
+-module(cow_sse).
+
+-export([init/0]).
+-export([parse/2]).
+-export([events/1]).
+-export([event/1]).
+
+-record(state, {
+ state_name = bom :: bom | events,
+ buffer = <<>> :: binary(),
+ last_event_id = <<>> :: binary(),
+ last_event_id_set = false :: boolean(),
+ event_type = <<>> :: binary(),
+ data = [] :: iolist(),
+ retry = undefined :: undefined | non_neg_integer()
+}).
+-type state() :: #state{}.
+-export_type([state/0]).
+
+-type parsed_event() :: #{
+ last_event_id := binary(),
+ event_type := binary(),
+ data := iolist()
+}.
+
+-type event() :: #{
+ comment => iodata(),
+ data => iodata(),
+ event => iodata() | atom(),
+ id => iodata(),
+ retry => non_neg_integer()
+}.
+-export_type([event/0]).
+
+-spec init() -> state().
+init() ->
+ #state{}.
+
+%% @todo Add a function to retrieve the retry value from the state.
+
+-spec parse(binary(), State)
+ -> {event, parsed_event(), State} | {more, State}
+ when State::state().
+parse(Data0, State=#state{state_name=bom, buffer=Buffer}) ->
+ Data1 = case Buffer of
+ <<>> -> Data0;
+ _ -> << Buffer/binary, Data0/binary >>
+ end,
+ case Data1 of
+ %% Skip the BOM.
+ << 16#fe, 16#ff, Data/bits >> ->
+ parse_event(Data, State#state{state_name=events, buffer= <<>>});
+ %% Not enough data to know wether we have a BOM.
+ << 16#fe >> ->
+ {more, State#state{buffer=Data1}};
+ <<>> ->
+ {more, State};
+ %% No BOM.
+ _ ->
+ parse_event(Data1, State#state{state_name=events, buffer= <<>>})
+ end;
+%% Try to process data from the buffer if there is no new input.
+parse(<<>>, State=#state{buffer=Buffer}) ->
+ parse_event(Buffer, State#state{buffer= <<>>});
+%% Otherwise process the input data as-is.
+parse(Data0, State=#state{buffer=Buffer}) ->
+ Data = case Buffer of
+ <<>> -> Data0;
+ _ -> << Buffer/binary, Data0/binary >>
+ end,
+ parse_event(Data, State).
+
+parse_event(Data, State0) ->
+ case binary:split(Data, [<<"\r\n">>, <<"\r">>, <<"\n">>]) of
+ [Line, Rest] ->
+ case parse_line(Line, State0) of
+ {ok, State} ->
+ parse_event(Rest, State);
+ {event, Event, State} ->
+ {event, Event, State#state{buffer=Rest}}
+ end;
+ [_] ->
+ {more, State0#state{buffer=Data}}
+ end.
+
+%% Dispatch events on empty line.
+parse_line(<<>>, State) ->
+ dispatch_event(State);
+%% Ignore comments.
+parse_line(<< $:, _/bits >>, State) ->
+ {ok, State};
+%% Normal line.
+parse_line(Line, State) ->
+ case binary:split(Line, [<<":\s">>, <<":">>]) of
+ [Field, Value] ->
+ process_field(Field, Value, State);
+ [Field] ->
+ process_field(Field, <<>>, State)
+ end.
+
+process_field(<<"event">>, Value, State) ->
+ {ok, State#state{event_type=Value}};
+process_field(<<"data">>, Value, State=#state{data=Data}) ->
+ {ok, State#state{data=[<<$\n>>, Value|Data]}};
+process_field(<<"id">>, Value, State) ->
+ {ok, State#state{last_event_id=Value, last_event_id_set=true}};
+process_field(<<"retry">>, Value, State) ->
+ try
+ {ok, State#state{retry=binary_to_integer(Value)}}
+ catch _:_ ->
+ {ok, State}
+ end;
+process_field(_, _, State) ->
+ {ok, State}.
+
+%% Data is an empty string; abort.
+dispatch_event(State=#state{last_event_id_set=false, data=[]}) ->
+ {ok, State#state{event_type= <<>>}};
+%% Data is an empty string but we have a last_event_id:
+%% propagate it on its own so that the caller knows the
+%% most recent ID.
+dispatch_event(State=#state{last_event_id=LastEventID, data=[]}) ->
+ {event, #{
+ last_event_id => LastEventID
+ }, State#state{last_event_id_set=false, event_type= <<>>}};
+%% Dispatch the event.
+%%
+%% Always remove the last linebreak from the data.
+dispatch_event(State=#state{last_event_id=LastEventID,
+ event_type=EventType, data=[_|Data]}) ->
+ {event, #{
+ last_event_id => LastEventID,
+ event_type => case EventType of
+ <<>> -> <<"message">>;
+ _ -> EventType
+ end,
+ data => lists:reverse(Data)
+ }, State#state{last_event_id_set=false, event_type= <<>>, data=[]}}.
+
+-ifdef(TEST).
+parse_example1_test() ->
+ {event, #{
+ event_type := <<"message">>,
+ last_event_id := <<>>,
+ data := Data
+ }, State} = parse(<<
+ "data: YHOO\n"
+ "data: +2\n"
+ "data: 10\n"
+ "\n">>, init()),
+ <<"YHOO\n+2\n10">> = iolist_to_binary(Data),
+ {more, _} = parse(<<>>, State),
+ ok.
+
+parse_example2_test() ->
+ {event, #{
+ event_type := <<"message">>,
+ last_event_id := <<"1">>,
+ data := Data1
+ }, State0} = parse(<<
+ ": test stream\n"
+ "\n"
+ "data: first event\n"
+ "id: 1\n"
+ "\n"
+ "data:second event\n"
+ "id\n"
+ "\n"
+ "data: third event\n"
+ "\n">>, init()),
+ <<"first event">> = iolist_to_binary(Data1),
+ {event, #{
+ event_type := <<"message">>,
+ last_event_id := <<>>,
+ data := Data2
+ }, State1} = parse(<<>>, State0),
+ <<"second event">> = iolist_to_binary(Data2),
+ {event, #{
+ event_type := <<"message">>,
+ last_event_id := <<>>,
+ data := Data3
+ }, State} = parse(<<>>, State1),
+ <<" third event">> = iolist_to_binary(Data3),
+ {more, _} = parse(<<>>, State),
+ ok.
+
+parse_example3_test() ->
+ {event, #{
+ event_type := <<"message">>,
+ last_event_id := <<>>,
+ data := Data1
+ }, State0} = parse(<<
+ "data\n"
+ "\n"
+ "data\n"
+ "data\n"
+ "\n"
+ "data:\n">>, init()),
+ <<>> = iolist_to_binary(Data1),
+ {event, #{
+ event_type := <<"message">>,
+ last_event_id := <<>>,
+ data := Data2
+ }, State} = parse(<<>>, State0),
+ <<"\n">> = iolist_to_binary(Data2),
+ {more, _} = parse(<<>>, State),
+ ok.
+
+parse_example4_test() ->
+ {event, Event, State0} = parse(<<
+ "data:test\n"
+ "\n"
+ "data: test\n"
+ "\n">>, init()),
+ {event, Event, State} = parse(<<>>, State0),
+ {more, _} = parse(<<>>, State),
+ ok.
+
+parse_id_without_data_test() ->
+ {event, Event1, State0} = parse(<<
+ "id: 1\n"
+ "\n"
+ "data: data\n"
+ "\n"
+ "id: 2\n"
+ "\n">>, init()),
+ 1 = maps:size(Event1),
+ #{last_event_id := <<"1">>} = Event1,
+ {event, #{
+ event_type := <<"message">>,
+ last_event_id := <<"1">>,
+ data := Data
+ }, State1} = parse(<<>>, State0),
+ <<"data">> = iolist_to_binary(Data),
+ {event, Event2, State} = parse(<<>>, State1),
+ 1 = maps:size(Event2),
+ #{last_event_id := <<"2">>} = Event2,
+ {more, _} = parse(<<>>, State),
+ ok.
+
+parse_repeated_id_without_data_test() ->
+ {event, Event1, State0} = parse(<<
+ "id: 1\n"
+ "\n"
+ "event: message\n" %% This will be ignored since there's no data.
+ "\n"
+ "id: 1\n"
+ "\n"
+ "id: 2\n"
+ "\n">>, init()),
+ {event, Event1, State1} = parse(<<>>, State0),
+ 1 = maps:size(Event1),
+ #{last_event_id := <<"1">>} = Event1,
+ {event, Event2, State} = parse(<<>>, State1),
+ 1 = maps:size(Event2),
+ #{last_event_id := <<"2">>} = Event2,
+ {more, _} = parse(<<>>, State),
+ ok.
+
+parse_split_event_test() ->
+ {more, State} = parse(<<
+ "data: AAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAA"
+ "AAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAA"
+ "AAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAA">>, init()),
+ {event, _, _} = parse(<<"==\n\n">>, State),
+ ok.
+-endif.
+
+-spec events([event()]) -> iolist().
+events(Events) ->
+ [event(Event) || Event <- Events].
+
+-spec event(event()) -> iolist().
+event(Event) ->
+ [
+ event_comment(Event),
+ event_id(Event),
+ event_name(Event),
+ event_data(Event),
+ event_retry(Event),
+ $\n
+ ].
+
+event_comment(#{comment := Comment}) ->
+ prefix_lines(Comment, <<>>);
+event_comment(_) ->
+ [].
+
+event_id(#{id := ID}) ->
+ nomatch = binary:match(iolist_to_binary(ID), <<"\n">>),
+ [<<"id: ">>, ID, $\n];
+event_id(_) ->
+ [].
+
+event_name(#{event := Name0}) ->
+ Name = if
+ is_atom(Name0) -> atom_to_binary(Name0, utf8);
+ true -> iolist_to_binary(Name0)
+ end,
+ nomatch = binary:match(Name, <<"\n">>),
+ [<<"event: ">>, Name, $\n];
+event_name(_) ->
+ [].
+
+event_data(#{data := Data}) ->
+ prefix_lines(Data, <<"data">>);
+event_data(_) ->
+ [].
+
+event_retry(#{retry := Retry}) ->
+ [<<"retry: ">>, integer_to_binary(Retry), $\n];
+event_retry(_) ->
+ [].
+
+prefix_lines(IoData, Prefix) ->
+ Lines = binary:split(iolist_to_binary(IoData), <<"\n">>, [global]),
+ [[Prefix, <<": ">>, Line, $\n] || Line <- Lines].
+
+-ifdef(TEST).
+event_test() ->
+ _ = event(#{}),
+ _ = event(#{comment => "test"}),
+ _ = event(#{data => "test"}),
+ _ = event(#{data => "test\ntest\ntest"}),
+ _ = event(#{data => "test\ntest\ntest\n"}),
+ _ = event(#{data => <<"test\ntest\ntest">>}),
+ _ = event(#{data => [<<"test">>, $\n, <<"test">>, [$\n, "test"]]}),
+ _ = event(#{event => test}),
+ _ = event(#{event => "test"}),
+ _ = event(#{id => "test"}),
+ _ = event(#{retry => 5000}),
+ _ = event(#{event => "test", data => "test"}),
+ _ = event(#{id => "test", event => "test", data => "test"}),
+ ok.
+-endif.