First working HTTPS over secure HTTP/2

Has a timer:sleep/1 though because there is currently no way
to wait for the TLS handshake to complete.

1 files changed, 61 insertions, 0 deletions

diff --git a/src/gun_tls_proxy_http2_connect.erl b/src/gun_tls_proxy_http2_connect.erl
new file mode 100644
index 0000000..e70454a
--- /dev/null
+++ b/src/gun_tls_proxy_http2_connect.erl
@@ -0,0 +1,61 @@
+%% Copyright (c) 2020, Loïc Hoguin <[email protected]>
+%%
+%% 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(gun_tls_proxy_http2_connect).
+
+-export([name/0]).
+-export([messages/0]).
+-export([connect/3]).
+-export([connect/4]).
+-export([send/2]).
+-export([setopts/2]).
+-export([sockname/1]).
+-export([close/1]).
+
+-type socket() :: #{
+	reply_to := pid(),
+	stream_ref := reference() | [reference()]
+}.
+
+name() -> tls_proxy_http2_connect.
+
+%% We need different message tags because the messages
+%% must be propagated to the right stream.
+messages() -> {tls_proxy_http2_connect, tls_proxy_http2_connect_closed, tls_proxy_http2_connect_error}.
+
+-spec connect(_, _, _) -> no_return().
+connect(_, _, _) ->
+	error(not_implemented).
+
+-spec connect(_, _, _, _) -> no_return().
+connect(_, _, _, _) ->
+	error(not_implemented).
+
+-spec send(socket(), iodata()) -> ok.
+send(#{gun_pid := GunPid, reply_to := ReplyTo, stream_ref := StreamRef}, Data) ->
+	GunPid ! {handle_continue, StreamRef, {data, ReplyTo, StreamRef, nofin, Data}},
+	ok.
+
+-spec setopts(_, _) -> no_return().
+setopts(_, _) ->
+%	error(not_implemented).
+	ok.
+
+-spec sockname(_) -> no_return().
+sockname(_) ->
+	error(not_implemented).
+
+-spec close(socket()) -> ok.
+close(_) ->
+	ok.