sgerrand / ex_teya / 25317360533

96%

push

github

refactor(sse): replace custom parser with req_server_sent_events

Drops the hand-rolled SSE frame parser and chunk-buffer receive loop in
Teya.SSE in favour of the req_server_sent_events plugin, which handles
the same SSE-spec edge cases (multi-line data, CRLF/LF, comments, id,
retry, partial-frame buffering).

Teya.SSE.stream/7 now attaches the plugin to a Req.Request with into: fun,
JSON-decodes the data field, filters non-map payloads, and forwards the
existing {ok_tag, id, event_type, data} and {error_tag, id, reason}
messages — so the public subscribe/2 protocol on Teya.POSLink.Payment
and Teya.POSLink.Receipt is unchanged. Stream stall detection now uses
Req's :receive_timeout, mapped from :sse_stream_timeout_ms.

Removes test/teya/sse_test.exs; parser-edge-case coverage lives in the
plugin. The integration-level subscribe tests continue to guard the
public message protocol.

9 of 10 new or added lines in 1 file covered. (90.0%)

146 of 152 relevant lines covered (96.05%)

14.55 hits per line