Packages

hackney

1.24.1
4.7.2 4.7.1 4.7.0 4.6.1 4.6.0 4.5.2 4.5.1 4.5.0 4.4.5 4.4.3 4.4.2 4.4.1 4.4.0 4.3.0 4.2.3 4.2.2 4.2.1 4.2.0 4.1.0 4.0.3 4.0.2 4.0.1 4.0.0 3.2.1 3.2.0 3.1.2 3.1.1 3.1.0 3.0.3 3.0.2 3.0.1 3.0.0 retired 2.0.1 2.0.0 2.0.0-beta.1 1.25.0 1.24.1 1.24.0 1.23.0 1.22.0 1.21.0 1.20.1 1.20.0 1.19.1 1.19.0 1.18.2 1.18.1 1.18.0 1.17.4 1.17.3 1.17.2 1.17.1 1.17.0 1.16.0 1.15.2 1.15.1 1.15.0 1.14.3 1.14.2 1.14.0 1.13.0 1.12.1 1.12.0 1.11.0 1.10.1 1.10.0 1.9.0 1.8.6 1.8.5 1.8.4 1.8.3 1.8.2 1.8.0 1.7.1 1.7.0 1.6.6 retired 1.6.5 1.6.4 retired 1.6.3 1.6.2 1.6.1 1.6.0 1.5.7 1.5.6 1.5.5 1.5.4 1.5.3 1.5.2 1.5.1 1.5.0 1.4.10 1.4.8 1.4.7 1.4.6 1.4.5 1.4.4 1.4.3 1.4.2 1.4.1 1.4.0 1.3.2 1.3.1 1.3.0 1.2.0 1.1.0 1.0.6 1.0.5 1.0.2 1.0.1 0.15.2 0.15.0 0.14.3 0.14.2 0.14.1 0.14.0 0.13.1

Simple HTTP client with HTTP/1.1, HTTP/2, and HTTP/3 support

Security advisory: This version has known vulnerabilities. View advisories
HexDocs

Current section

Files

Jump to
Readme
116 Versions
7 Dependencies
Dependants
12 Advisories
Files
Activity
hackney src hackney_connection.erl
Raw

src/hackney_connection.erl 

%%% -*- erlang -*-

%%%

%%% This file is part of hackney released under the Apache 2 license.

%%% See the NOTICE for more information



-module(hackney_connection).





-export([new/1,

         get_property/2,

         is_ssl/1]).





%% helpers

-export([controlling_process/3]).

-export([setopts/3]).

-export([sync_socket/2]).

-export([connect/3]).

-export([close/2]).



-export([connect_options/3]).

-export([ssl_opts/2]).

-export([merge_ssl_opts/2]).



-include("hackney.hrl").





new(#client{transport=Transport,

            host=Host0,

            port=Port,

            options=ClientOptions}) ->

  Host1 = string_compat:to_lower(Host0),

  ConnectOptions = connect_options(Transport, Host1, ClientOptions),

  Tunnel = maybe_tunnel(Transport),

  Id = new_connection_id(Transport, Host1, Port, ConnectOptions),

  Connection = new_connection_r(Transport, Host1, Port, Id, Tunnel),

  {Connection, ConnectOptions}.



get_property(transport, #connection{transport=Transport}) -> Transport;

get_property(host, #connection{host=Host}) -> Host;

get_property(port, #connection{port=Port}) -> Port;

get_property(id, #connection{id=Id}) -> Id;

get_property(_, _) -> erlang:error(badarg).





is_ssl(#connection{transport=hackney_ssl}) -> true;

is_ssl(#connection{}) -> false;

is_ssl(_) -> erlang:error(badarg).



controlling_process(#connection{transport=Transport}, Socket, Owner) ->

  Transport:controlling_process(Socket, Owner).





setopts(#connection{transport=Transport}, Socket, Opts) ->

  Transport:setopts(Socket, Opts).





%% check that no events from the sockets is received after setting it to

%% passive.

sync_socket(#connection{transport=Transport}, Socket) ->

  {Msg, MsgClosed, MsgError} = Transport:messages(Socket),

  receive

    {Msg, Socket, _} -> false;

    {MsgClosed, Socket} -> false;

    {MsgError, Socket, _} -> false

  after 0 ->

          true

  end.





connect(#connection{transport=Transport,

                    host=Host,

                    port=Port}, ConnectOptions, Timeout) ->

  Transport:connect(Host, Port, ConnectOptions, Timeout).





close(#connection{transport=Transport}, Socket) ->

  Transport:close(Socket).





new_connection_id(Transport, Host, Port, ConnectionOptions) ->

  Key = {Transport, Host, Port, ConnectionOptions},

  case hackney_connections:lookup(Key) of

    {ok, Id} ->

      Id;

    error ->

      Id = erlang:phash2(Key),

      hackney_connections:insert(Key, Id),

      Id

  end.





new_connection_r(Transport, Host, Port, Id, Tunnel) ->

  #connection{transport=Transport,

              host=Host,

              port=Port,

              id=Id,

              tunnel=Tunnel}.





connect_options(hackney_local_tcp, _Host, ClientOptions) ->

  proplists:get_value(connect_options, ClientOptions, []);



connect_options(Transport, Host, ClientOptions) ->

  ConnectOpts = proplists:get_value(connect_options, ClientOptions, []),



  case Transport of

    hackney_ssl ->

      [{ssl_options, ssl_opts(Host, ClientOptions)} | ConnectOpts];

    _ ->

      ConnectOpts

  end.





ssl_opts(Host, Options) ->

  case proplists:get_value(ssl_options, Options) of

    undefined ->

      ssl_opts_1(Host, Options);

    [] ->

      ssl_opts_1(Host, Options);

    SSLOpts ->

      merge_ssl_opts(Host, SSLOpts)

  end.



ssl_opts_1(Host, Options) ->

  Insecure =  proplists:get_value(insecure, Options, false),

  case Insecure of

    true ->

      [{verify, verify_none} | ssl_opts_2()];

    false ->

      hackney_ssl:check_hostname_opts(Host) ++ ssl_opts_2()

  end.



ssl_opts_2() ->

  hackney_ssl:cipher_opts().



merge_ssl_opts(Host, OverrideOpts) ->

  DefaultOpts = ssl_opts_1(Host, OverrideOpts),

  MergedOpts = orddict:merge(fun(_K, _V1, V) -> V end,

                             orddict:from_list(DefaultOpts),

                             orddict:from_list(OverrideOpts)),

  %% If cacertfile was provided in override opts remove cacerts

  case lists:keymember(cacertfile, 1, MergedOpts) of

    true ->

      lists:keydelete(cacerts, 1, MergedOpts);

    false ->

      MergedOpts

  end.



maybe_tunnel(hackney_http_connect) ->

  true;

maybe_tunnel(_) ->

  false.