aboutsummaryrefslogtreecommitdiffstats
path: root/test
diff options
context:
space:
mode:
Diffstat (limited to 'test')
-rw-r--r--test/event_SUITE.erl28
1 files changed, 27 insertions, 1 deletions
diff --git a/test/event_SUITE.erl b/test/event_SUITE.erl
index d593a59..977eec4 100644
--- a/test/event_SUITE.erl
+++ b/test/event_SUITE.erl
@@ -822,7 +822,7 @@ ws_protocol_changed(Config) ->
http1_protocol_changed_connect(Config) ->
doc("Confirm that the protocol_changed event callback is called on CONNECT success "
- "when connecting through a TLS server via a TCP proxy."),
+ "when connecting through a TCP server via a TCP proxy."),
OriginPort = config(tcp_origin_port, Config),
{ok, _, ProxyPort} = rfc7231_SUITE:do_proxy_start(tcp),
{ok, ConnPid} = gun:open("localhost", ProxyPort, #{
@@ -905,6 +905,28 @@ http1_transport_changed_connect_over_https_proxy(Config) ->
true = is_pid(Socket),
gun:close(ConnPid).
+http1_origin_changed_connect(Config) ->
+ doc("Confirm that the origin_changed event callback is called on CONNECT success."),
+ OriginPort = config(tcp_origin_port, Config),
+ {ok, _, ProxyPort} = rfc7231_SUITE:do_proxy_start(tcp),
+ {ok, ConnPid} = gun:open("localhost", ProxyPort, #{
+ event_handler => {?MODULE, self()},
+ protocols => [config(name, config(tc_group_properties, Config))],
+ transport => tcp
+ }),
+ {ok, http} = gun:await_up(ConnPid),
+ _ = gun:connect(ConnPid, #{
+ host => "localhost",
+ port => OriginPort
+ }),
+ #{
+ type := connect,
+ origin_scheme := <<"http">>,
+ origin_host := "localhost",
+ origin_port := OriginPort
+ } = do_receive_event(origin_changed),
+ gun:close(ConnPid).
+
cancel(Config) ->
doc("Confirm that the cancel event callback is called when we cancel a stream."),
{ok, Pid, _} = do_gun_open(Config),
@@ -1095,6 +1117,10 @@ transport_changed(EventData, Pid) ->
Pid ! {?FUNCTION_NAME, EventData},
Pid.
+origin_changed(EventData, Pid) ->
+ Pid ! {?FUNCTION_NAME, EventData},
+ Pid.
+
cancel(EventData, Pid) ->
Pid ! {?FUNCTION_NAME, EventData},
Pid.