proxy_protocol.erl 730 B

12345678910111213141516171819202122232425262728
  1. -module(proxy_protocol).
  2. -behaviour(ranch_protocol).
  3. -export([start_link/4]).
  4. -export([init/3]).
  5. start_link(Ref, _Socket, Transport, Opts) ->
  6. Pid = spawn_link(?MODULE, init, [Ref, Transport, Opts]),
  7. {ok, Pid}.
  8. init(Ref, Transport, _Opts = []) ->
  9. {ok, ProxyInfo} = ranch:recv_proxy_header(Ref, 1000),
  10. {ok, Socket} = ranch:handshake(Ref),
  11. Pid = case Transport of
  12. ranch_tcp -> ct_helper:get_remote_pid_tcp(Socket);
  13. ranch_ssl -> ct_helper:get_remote_pid_tls(Socket)
  14. end,
  15. Pid ! {?MODULE, ProxyInfo},
  16. loop(Socket, Transport).
  17. loop(Socket, Transport) ->
  18. case Transport:recv(Socket, 0, 5000) of
  19. {ok, Data} ->
  20. _ = Transport:send(Socket, Data),
  21. loop(Socket, Transport);
  22. _ ->
  23. ok = Transport:close(Socket)
  24. end.