2004-03-02 22:16:55 +01:00
|
|
|
%%%----------------------------------------------------------------------
|
|
|
|
|
%%% File : ejabberd_http.erl
|
2007-12-24 14:57:53 +01:00
|
|
|
%%% Author : Alexey Shchepin <alexey@process-one.net>
|
2007-05-07 17:47:33 +02:00
|
|
|
%%% Purpose :
|
2007-12-24 14:57:53 +01:00
|
|
|
%%% Created : 27 Feb 2004 by Alexey Shchepin <alexey@process-one.net>
|
|
|
|
|
%%%
|
|
|
|
|
%%%
|
2021-01-27 16:55:25 +01:00
|
|
|
%%% ejabberd, Copyright (C) 2002-2021 ProcessOne
|
2007-12-24 14:57:53 +01:00
|
|
|
%%%
|
|
|
|
|
%%% This program is free software; you can redistribute it and/or
|
|
|
|
|
%%% modify it under the terms of the GNU General Public License as
|
|
|
|
|
%%% published by the Free Software Foundation; either version 2 of the
|
|
|
|
|
%%% License, or (at your option) any later version.
|
|
|
|
|
%%%
|
|
|
|
|
%%% This program is distributed in the hope that it will be useful,
|
|
|
|
|
%%% but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
|
|
|
%%% MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
|
|
|
|
|
%%% General Public License for more details.
|
2009-01-12 15:44:42 +01:00
|
|
|
%%%
|
2014-02-22 11:27:40 +01:00
|
|
|
%%% You should have received a copy of the GNU General Public License along
|
|
|
|
|
%%% with this program; if not, write to the Free Software Foundation, Inc.,
|
|
|
|
|
%%% 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
|
2007-12-24 14:57:53 +01:00
|
|
|
%%%
|
2004-03-02 22:16:55 +01:00
|
|
|
%%%----------------------------------------------------------------------
|
|
|
|
|
|
|
|
|
|
-module(ejabberd_http).
|
2018-09-17 10:21:02 +02:00
|
|
|
-behaviour(ejabberd_listener).
|
2015-06-01 14:38:27 +02:00
|
|
|
|
2007-12-24 14:57:53 +01:00
|
|
|
-author('alexey@process-one.net').
|
2004-03-02 22:16:55 +01:00
|
|
|
|
|
|
|
|
%% External exports
|
2019-04-01 15:53:28 +02:00
|
|
|
-export([start/3, start_link/3,
|
2018-09-17 10:21:02 +02:00
|
|
|
accept/1, receive_headers/1, recv_file/2,
|
2020-02-21 12:19:02 +01:00
|
|
|
listen_opt_type/1, listen_options/0,
|
|
|
|
|
apply_custom_headers/2]).
|
2004-03-02 22:16:55 +01:00
|
|
|
|
2019-06-14 11:33:26 +02:00
|
|
|
-export([init/3]).
|
2009-12-07 18:33:02 +01:00
|
|
|
|
2013-04-08 11:12:54 +02:00
|
|
|
-include("logger.hrl").
|
2020-09-03 13:45:57 +02:00
|
|
|
-include_lib("xmpp/include/xmpp.hrl").
|
2004-03-04 21:56:32 +01:00
|
|
|
-include("ejabberd_http.hrl").
|
2018-05-14 18:30:21 +02:00
|
|
|
-include_lib("kernel/include/file.hrl").
|
2004-03-02 22:16:55 +01:00
|
|
|
|
|
|
|
|
-record(state, {sockmod,
|
|
|
|
|
socket,
|
|
|
|
|
request_method,
|
2004-07-06 23:34:50 +02:00
|
|
|
request_version,
|
2004-03-02 22:16:55 +01:00
|
|
|
request_path,
|
|
|
|
|
request_auth,
|
2004-09-30 23:54:39 +02:00
|
|
|
request_keepalive,
|
2018-05-14 18:30:21 +02:00
|
|
|
request_content_length = 0,
|
2014-04-06 00:39:51 +02:00
|
|
|
request_lang = <<"en">>,
|
2007-01-25 06:53:58 +01:00
|
|
|
%% XXX bard: request handlers are configured in
|
|
|
|
|
%% ejabberd.cfg under the HTTP service. For example,
|
|
|
|
|
%% to have the module test_web handle requests with
|
|
|
|
|
%% paths starting with "/test/module":
|
|
|
|
|
%%
|
2015-04-15 10:47:10 +02:00
|
|
|
%% {5280, ejabberd_http, [http_bind, web_admin,
|
2007-01-25 06:53:58 +01:00
|
|
|
%% {request_handlers, [{["test", "module"], mod_test_web}]}]}
|
|
|
|
|
%%
|
|
|
|
|
request_handlers = [],
|
2008-09-12 13:45:16 +02:00
|
|
|
request_host,
|
|
|
|
|
request_port,
|
|
|
|
|
request_tp,
|
|
|
|
|
request_headers = [],
|
2004-09-25 22:52:20 +02:00
|
|
|
end_of_request = false,
|
2014-10-03 16:53:55 +02:00
|
|
|
options = [],
|
2012-02-14 11:35:17 +01:00
|
|
|
default_host,
|
2017-03-27 23:19:11 +02:00
|
|
|
custom_headers,
|
2017-02-24 10:25:16 +01:00
|
|
|
trail = <<>>,
|
2018-12-04 14:22:18 +01:00
|
|
|
addr_re,
|
|
|
|
|
sock_peer_name = none
|
2004-03-02 22:16:55 +01:00
|
|
|
}).
|
|
|
|
|
|
|
|
|
|
-define(XHTML_DOCTYPE,
|
2013-03-14 10:33:02 +01:00
|
|
|
<<"<?xml version='1.0'?>\n<!DOCTYPE html "
|
|
|
|
|
"PUBLIC \"-//W3C//DTD XHTML 1.0 Transitional//"
|
|
|
|
|
"EN\" \"http://www.w3.org/TR/xhtml1/DTD/xhtml1"
|
|
|
|
|
"-transitional.dtd\">\n">>).
|
2004-03-02 22:16:55 +01:00
|
|
|
|
2004-04-26 17:38:07 +02:00
|
|
|
-define(HTML_DOCTYPE,
|
2013-03-14 10:33:02 +01:00
|
|
|
<<"<!DOCTYPE html PUBLIC \"-//W3C//DTD "
|
|
|
|
|
"XHTML 1.0 Transitional//EN\" \"http://www.w3."
|
|
|
|
|
"org/TR/xhtml1/DTD/xhtml1-transitional.dtd\">\n"
|
|
|
|
|
"">>).
|
2004-03-02 22:16:55 +01:00
|
|
|
|
2018-05-14 18:30:21 +02:00
|
|
|
-define(RECV_BUF, 65536).
|
|
|
|
|
-define(SEND_BUF, 65536).
|
|
|
|
|
-define(MAX_POST_SIZE, 20971520). %% 20Mb
|
|
|
|
|
|
2019-04-01 15:53:28 +02:00
|
|
|
start(SockMod, Socket, Opts) ->
|
2015-12-09 15:40:20 +01:00
|
|
|
{ok,
|
|
|
|
|
proc_lib:spawn(ejabberd_http, init,
|
2019-04-01 15:53:28 +02:00
|
|
|
[SockMod, Socket, Opts])}.
|
2004-03-02 22:16:55 +01:00
|
|
|
|
2019-04-01 15:53:28 +02:00
|
|
|
start_link(SockMod, Socket, Opts) ->
|
2013-03-14 10:33:02 +01:00
|
|
|
{ok,
|
|
|
|
|
proc_lib:spawn_link(ejabberd_http, init,
|
2019-04-01 15:53:28 +02:00
|
|
|
[SockMod, Socket, Opts])}.
|
2009-12-07 18:33:02 +01:00
|
|
|
|
2019-04-01 15:53:28 +02:00
|
|
|
init(SockMod, Socket, Opts) ->
|
2013-08-12 14:25:05 +02:00
|
|
|
TLSEnabled = proplists:get_bool(tls, Opts),
|
2017-12-24 10:27:51 +01:00
|
|
|
TLSOpts1 = lists:filter(fun ({ciphers, _}) -> true;
|
2015-05-26 21:06:04 +02:00
|
|
|
({dhfile, _}) -> true;
|
2018-09-18 11:53:36 +02:00
|
|
|
({cafile, _}) -> true;
|
2017-04-30 18:01:47 +02:00
|
|
|
({protocol_options, _}) -> true;
|
2013-03-14 10:33:02 +01:00
|
|
|
(_) -> false
|
|
|
|
|
end,
|
|
|
|
|
Opts),
|
2017-04-30 18:01:47 +02:00
|
|
|
TLSOpts2 = case proplists:get_bool(tls_compression, Opts) of
|
|
|
|
|
false -> [compression_none | TLSOpts1];
|
|
|
|
|
true -> TLSOpts1
|
2013-07-17 14:28:23 +02:00
|
|
|
end,
|
2019-06-14 11:33:26 +02:00
|
|
|
TLSOpts3 = case ejabberd_pkix:get_certfile(
|
|
|
|
|
ejabberd_config:get_myname()) of
|
|
|
|
|
error -> TLSOpts2;
|
|
|
|
|
{ok, CertFile} -> [{certfile, CertFile}|TLSOpts2]
|
2017-12-24 10:27:51 +01:00
|
|
|
end,
|
|
|
|
|
TLSOpts = [verify_none | TLSOpts3],
|
2013-03-14 10:33:02 +01:00
|
|
|
{SockMod1, Socket1} = if TLSEnabled ->
|
2018-05-14 18:30:21 +02:00
|
|
|
inet:setopts(Socket, [{recbuf, ?RECV_BUF}]),
|
2016-02-03 16:13:16 +01:00
|
|
|
{ok, TLSSocket} = fast_tls:tcp_to_tls(Socket,
|
2013-03-14 10:33:02 +01:00
|
|
|
TLSOpts),
|
2016-02-03 16:13:16 +01:00
|
|
|
{fast_tls, TLSSocket};
|
2013-03-14 10:33:02 +01:00
|
|
|
true -> {SockMod, Socket}
|
|
|
|
|
end,
|
2018-12-04 14:22:18 +01:00
|
|
|
SockPeer = proplists:get_value(sock_peer_name, Opts, none),
|
2019-06-14 11:33:26 +02:00
|
|
|
RequestHandlers = proplists:get_value(request_handlers, Opts, []),
|
2007-01-25 06:53:58 +01:00
|
|
|
?DEBUG("S: ~p~n", [RequestHandlers]),
|
|
|
|
|
|
2017-02-24 10:25:16 +01:00
|
|
|
{ok, RE} = re:compile(<<"^(?:\\[(.*?)\\]|(.*?))(?::(\\d+))?$">>),
|
2012-02-14 11:35:17 +01:00
|
|
|
|
2017-05-08 13:34:35 +02:00
|
|
|
CustomHeaders = proplists:get_value(custom_headers, Opts, []),
|
2017-03-27 23:19:11 +02:00
|
|
|
|
2009-12-08 18:32:46 +01:00
|
|
|
State = #state{sockmod = SockMod1,
|
|
|
|
|
socket = Socket1,
|
2017-03-27 23:19:11 +02:00
|
|
|
custom_headers = CustomHeaders,
|
2014-10-03 16:53:55 +02:00
|
|
|
options = Opts,
|
2017-02-24 10:25:16 +01:00
|
|
|
request_handlers = RequestHandlers,
|
2018-12-04 14:22:18 +01:00
|
|
|
sock_peer_name = SockPeer,
|
2017-02-24 10:25:16 +01:00
|
|
|
addr_re = RE},
|
2015-08-17 15:50:02 +02:00
|
|
|
try receive_headers(State) of
|
|
|
|
|
V -> V
|
|
|
|
|
catch
|
|
|
|
|
{error, _} -> State
|
|
|
|
|
end.
|
2004-03-02 22:16:55 +01:00
|
|
|
|
2018-09-17 10:21:02 +02:00
|
|
|
accept(_Pid) ->
|
2015-10-07 00:06:58 +02:00
|
|
|
ok.
|
2006-01-13 02:55:20 +01:00
|
|
|
|
2018-05-14 18:30:21 +02:00
|
|
|
send_text(_State, none) ->
|
|
|
|
|
ok;
|
2004-03-02 22:16:55 +01:00
|
|
|
send_text(State, Text) ->
|
2018-05-14 18:30:21 +02:00
|
|
|
case (State#state.sockmod):send(State#state.socket, Text) of
|
|
|
|
|
ok -> ok;
|
|
|
|
|
{error, timeout} ->
|
|
|
|
|
?INFO_MSG("Timeout on ~p:send", [State#state.sockmod]),
|
|
|
|
|
exit(normal);
|
|
|
|
|
Error ->
|
|
|
|
|
?DEBUG("Error in ~p:send: ~p",
|
|
|
|
|
[State#state.sockmod, Error]),
|
|
|
|
|
exit(normal)
|
|
|
|
|
end.
|
|
|
|
|
|
|
|
|
|
send_file(State, Fd, Size, FileName) ->
|
|
|
|
|
try
|
|
|
|
|
case State#state.sockmod of
|
|
|
|
|
gen_tcp ->
|
|
|
|
|
case file:sendfile(Fd, State#state.socket, 0, Size, []) of
|
|
|
|
|
{ok, _} -> ok
|
|
|
|
|
end;
|
|
|
|
|
_ ->
|
|
|
|
|
case file:read(Fd, ?SEND_BUF) of
|
|
|
|
|
{ok, Data} ->
|
|
|
|
|
send_text(State, Data),
|
|
|
|
|
send_file(State, Fd, Size, FileName);
|
|
|
|
|
eof ->
|
|
|
|
|
ok
|
|
|
|
|
end
|
|
|
|
|
end
|
|
|
|
|
catch _:{case_clause, {error, Why}} ->
|
|
|
|
|
if Why /= closed ->
|
2019-09-23 14:17:20 +02:00
|
|
|
?WARNING_MSG("Failed to read ~ts: ~ts",
|
2018-09-19 22:12:14 +02:00
|
|
|
[FileName, file_format_error(Why)]),
|
2018-05-14 18:30:21 +02:00
|
|
|
exit(normal);
|
|
|
|
|
true ->
|
|
|
|
|
ok
|
|
|
|
|
end
|
2009-10-19 11:36:23 +02:00
|
|
|
end.
|
2004-03-02 22:16:55 +01:00
|
|
|
|
2013-03-14 10:33:02 +01:00
|
|
|
receive_headers(#state{trail = Trail} = State) ->
|
2004-04-26 17:38:07 +02:00
|
|
|
SockMod = State#state.sockmod,
|
|
|
|
|
Socket = State#state.socket,
|
|
|
|
|
Data = SockMod:recv(Socket, 0, 300000),
|
2015-02-25 14:36:48 +01:00
|
|
|
case Data of
|
2020-07-28 12:18:18 +02:00
|
|
|
{error, closed} when State#state.request_method == undefined ->
|
|
|
|
|
% socket closed without receiving anything in it
|
|
|
|
|
ok;
|
2020-04-07 13:49:50 +02:00
|
|
|
{error, Error} ->
|
|
|
|
|
?DEBUG("Error when retrieving http headers ~p: ~p",
|
|
|
|
|
[State#state.sockmod, Error]),
|
|
|
|
|
ok;
|
2015-02-25 14:36:48 +01:00
|
|
|
{ok, D} ->
|
|
|
|
|
parse_headers(State#state{trail = <<Trail/binary, D/binary>>})
|
2012-04-06 16:22:08 +02:00
|
|
|
end.
|
|
|
|
|
|
|
|
|
|
parse_headers(#state{trail = <<>>} = State) ->
|
|
|
|
|
receive_headers(State);
|
2013-03-14 10:33:02 +01:00
|
|
|
parse_headers(#state{request_method = Method,
|
|
|
|
|
trail = Data} =
|
|
|
|
|
State) ->
|
2012-04-06 16:22:08 +02:00
|
|
|
PktType = case Method of
|
2015-10-07 00:06:58 +02:00
|
|
|
undefined -> http_bin;
|
|
|
|
|
_ -> httph_bin
|
|
|
|
|
end,
|
2013-06-24 12:04:56 +02:00
|
|
|
case erlang:decode_packet(PktType, Data, []) of
|
2015-10-07 00:06:58 +02:00
|
|
|
{ok, Pkt, Rest} ->
|
|
|
|
|
NewState = process_header(State#state{trail = Rest}, {ok, Pkt}),
|
2012-04-06 16:22:08 +02:00
|
|
|
case NewState#state.end_of_request of
|
2015-10-07 00:06:58 +02:00
|
|
|
true -> ok;
|
|
|
|
|
_ -> parse_headers(NewState)
|
2012-04-06 16:22:08 +02:00
|
|
|
end;
|
2015-10-07 00:06:58 +02:00
|
|
|
{more, _} ->
|
|
|
|
|
receive_headers(State#state{trail = Data});
|
|
|
|
|
_ ->
|
|
|
|
|
ok
|
2004-09-25 22:52:20 +02:00
|
|
|
end.
|
|
|
|
|
|
|
|
|
|
process_header(State, Data) ->
|
|
|
|
|
SockMod = State#state.sockmod,
|
|
|
|
|
Socket = State#state.socket,
|
2004-03-02 22:16:55 +01:00
|
|
|
case Data of
|
2013-03-14 10:33:02 +01:00
|
|
|
{ok, {http_request, Method, Uri, Version}} ->
|
|
|
|
|
KeepAlive = case Version of
|
|
|
|
|
{1, 1} -> true;
|
|
|
|
|
_ -> false
|
|
|
|
|
end,
|
|
|
|
|
Path = case Uri of
|
|
|
|
|
{absoluteURI, _Scheme, _Host, _Port, P} ->
|
|
|
|
|
{abs_path, P};
|
|
|
|
|
{abs_path, P} ->
|
|
|
|
|
{abs_path, P};
|
|
|
|
|
_ -> Uri
|
|
|
|
|
end,
|
|
|
|
|
State#state{request_method = Method,
|
|
|
|
|
request_version = Version, request_path = Path,
|
|
|
|
|
request_keepalive = KeepAlive};
|
|
|
|
|
{ok, {http_header, _, 'Connection' = Name, _, Conn}} ->
|
2017-04-11 12:13:58 +02:00
|
|
|
KeepAlive1 = case misc:tolower(Conn) of
|
2013-03-14 10:33:02 +01:00
|
|
|
<<"keep-alive">> -> true;
|
|
|
|
|
<<"close">> -> false;
|
|
|
|
|
_ -> State#state.request_keepalive
|
|
|
|
|
end,
|
|
|
|
|
State#state{request_keepalive = KeepAlive1,
|
|
|
|
|
request_headers = add_header(Name, Conn, State)};
|
|
|
|
|
{ok,
|
|
|
|
|
{http_header, _, 'Authorization' = Name, _, Auth}} ->
|
|
|
|
|
State#state{request_auth = parse_auth(Auth),
|
|
|
|
|
request_headers = add_header(Name, Auth, State)};
|
|
|
|
|
{ok,
|
|
|
|
|
{http_header, _, 'Content-Length' = Name, _, SLen}} ->
|
2016-09-24 22:34:28 +02:00
|
|
|
case catch binary_to_integer(SLen) of
|
2013-03-14 10:33:02 +01:00
|
|
|
Len when is_integer(Len) ->
|
|
|
|
|
State#state{request_content_length = Len,
|
|
|
|
|
request_headers = add_header(Name, SLen, State)};
|
|
|
|
|
_ -> State
|
|
|
|
|
end;
|
|
|
|
|
{ok,
|
|
|
|
|
{http_header, _, 'Accept-Language' = Name, _, Langs}} ->
|
|
|
|
|
State#state{request_lang = parse_lang(Langs),
|
|
|
|
|
request_headers = add_header(Name, Langs, State)};
|
2019-06-23 12:12:00 +02:00
|
|
|
{ok, {http_header, _, 'Host' = Name, _, Value}} ->
|
|
|
|
|
{Host, Port, TP} = get_transfer_protocol(State#state.addr_re, SockMod, Value),
|
2013-03-14 10:33:02 +01:00
|
|
|
State#state{request_host = Host,
|
2019-06-23 12:12:00 +02:00
|
|
|
request_port = Port,
|
|
|
|
|
request_tp = TP,
|
|
|
|
|
request_headers = add_header(Name, Value, State)};
|
2015-02-25 14:36:48 +01:00
|
|
|
{ok, {http_header, _, Name, _, Value}} when is_binary(Name) ->
|
2015-10-07 00:06:58 +02:00
|
|
|
State#state{request_headers =
|
|
|
|
|
add_header(normalize_header_name(Name), Value, State)};
|
2013-03-14 10:33:02 +01:00
|
|
|
{ok, {http_header, _, Name, _, Value}} ->
|
|
|
|
|
State#state{request_headers =
|
|
|
|
|
add_header(Name, Value, State)};
|
2019-06-23 12:12:00 +02:00
|
|
|
{ok, http_eoh} when State#state.request_host == undefined;
|
|
|
|
|
State#state.request_host == error ->
|
2017-10-11 17:53:53 +02:00
|
|
|
{State1, Out} = process_request(State),
|
|
|
|
|
send_text(State1, Out),
|
|
|
|
|
process_header(State, {ok, {http_error, <<>>}});
|
2013-03-14 10:33:02 +01:00
|
|
|
{ok, http_eoh} ->
|
2019-08-13 17:30:28 +02:00
|
|
|
?DEBUG("(~w) http query: ~w ~p~n",
|
|
|
|
|
[State#state.socket, State#state.request_method,
|
|
|
|
|
element(2, State#state.request_path)]),
|
|
|
|
|
{State3, Out} = process_request(State),
|
|
|
|
|
send_text(State3, Out),
|
|
|
|
|
case State3#state.request_keepalive of
|
|
|
|
|
true ->
|
|
|
|
|
#state{sockmod = SockMod, socket = Socket,
|
|
|
|
|
trail = State3#state.trail,
|
|
|
|
|
options = State#state.options,
|
|
|
|
|
default_host = State#state.default_host,
|
|
|
|
|
custom_headers = State#state.custom_headers,
|
|
|
|
|
request_handlers = State#state.request_handlers,
|
|
|
|
|
addr_re = State#state.addr_re};
|
|
|
|
|
_ ->
|
|
|
|
|
#state{end_of_request = true,
|
|
|
|
|
trail = State3#state.trail,
|
|
|
|
|
options = State#state.options,
|
|
|
|
|
default_host = State#state.default_host,
|
|
|
|
|
custom_headers = State#state.custom_headers,
|
|
|
|
|
request_handlers = State#state.request_handlers,
|
|
|
|
|
addr_re = State#state.addr_re}
|
|
|
|
|
end;
|
2013-03-14 10:33:02 +01:00
|
|
|
_ ->
|
|
|
|
|
#state{end_of_request = true,
|
2015-01-15 17:39:12 +01:00
|
|
|
options = State#state.options,
|
2015-03-06 12:40:48 +01:00
|
|
|
default_host = State#state.default_host,
|
2017-03-27 23:19:11 +02:00
|
|
|
custom_headers = State#state.custom_headers,
|
2017-02-24 11:25:10 +01:00
|
|
|
request_handlers = State#state.request_handlers,
|
|
|
|
|
addr_re = State#state.addr_re}
|
2007-01-25 06:53:58 +01:00
|
|
|
end.
|
|
|
|
|
|
2013-03-14 10:33:02 +01:00
|
|
|
add_header(Name, Value, State)->
|
2008-11-12 10:58:28 +01:00
|
|
|
[{Name, Value} | State#state.request_headers].
|
|
|
|
|
|
2017-02-24 10:25:16 +01:00
|
|
|
get_transfer_protocol(RE, SockMod, HostPort) ->
|
|
|
|
|
{Proto, DefPort} = case SockMod of
|
|
|
|
|
gen_tcp -> {http, 80};
|
|
|
|
|
fast_tls -> {https, 443}
|
|
|
|
|
end,
|
|
|
|
|
{Host, Port} = case re:run(HostPort, RE, [{capture,[1,2,3],binary}]) of
|
|
|
|
|
nomatch ->
|
2019-06-23 12:12:00 +02:00
|
|
|
{error, DefPort};
|
2017-02-24 10:25:16 +01:00
|
|
|
{match, [<<>>, H, <<>>]} ->
|
2019-06-23 12:12:00 +02:00
|
|
|
{jid:nameprep(H), DefPort};
|
2017-02-24 10:25:16 +01:00
|
|
|
{match, [H, <<>>, <<>>]} ->
|
2019-06-23 12:12:00 +02:00
|
|
|
{jid:nameprep(H), DefPort};
|
2017-02-24 10:25:16 +01:00
|
|
|
{match, [<<>>, H, PortStr]} ->
|
2019-06-23 12:12:00 +02:00
|
|
|
{jid:nameprep(H), binary_to_integer(PortStr)};
|
2017-02-24 10:25:16 +01:00
|
|
|
{match, [H, <<>>, PortStr]} ->
|
2019-06-23 12:12:00 +02:00
|
|
|
{jid:nameprep(H), binary_to_integer(PortStr)}
|
2017-02-24 10:25:16 +01:00
|
|
|
end,
|
|
|
|
|
|
|
|
|
|
{Host, Port, Proto}.
|
2008-09-12 13:45:16 +02:00
|
|
|
|
2007-01-25 06:53:58 +01:00
|
|
|
%% XXX bard: search through request handlers looking for one that
|
|
|
|
|
%% matches the requested URL path, and pass control to it. If none is
|
|
|
|
|
%% found, answer with HTTP 404.
|
2015-02-25 10:42:59 +01:00
|
|
|
|
2018-05-14 18:30:21 +02:00
|
|
|
process([], _) -> ejabberd_web:error(not_found);
|
|
|
|
|
process(Handlers, Request) ->
|
2015-02-25 10:42:59 +01:00
|
|
|
{HandlerPathPrefix, HandlerModule, HandlerOpts, HandlersLeft} =
|
|
|
|
|
case Handlers of
|
|
|
|
|
[{Pfx, Mod} | Tail] ->
|
|
|
|
|
{Pfx, Mod, [], Tail};
|
|
|
|
|
[{Pfx, Mod, Opts} | Tail] ->
|
|
|
|
|
{Pfx, Mod, Opts, Tail}
|
|
|
|
|
end,
|
|
|
|
|
|
|
|
|
|
case (lists:prefix(HandlerPathPrefix, Request#request.path) or
|
|
|
|
|
(HandlerPathPrefix==Request#request.path)) of
|
|
|
|
|
true ->
|
|
|
|
|
?DEBUG("~p matches ~p", [Request#request.path, HandlerPathPrefix]),
|
|
|
|
|
%% LocalPath is the path "local to the handler", i.e. if
|
|
|
|
|
%% the handler was registered to handle "/test/" and the
|
|
|
|
|
%% requested path is "/test/foo/bar", the local path is
|
|
|
|
|
%% ["foo", "bar"]
|
|
|
|
|
LocalPath = lists:nthtail(length(HandlerPathPrefix), Request#request.path),
|
2019-04-23 15:19:26 +02:00
|
|
|
R = case erlang:function_exported(HandlerModule, socket_handoff, 3) of
|
|
|
|
|
true ->
|
|
|
|
|
HandlerModule:socket_handoff(
|
|
|
|
|
LocalPath, Request, HandlerOpts);
|
|
|
|
|
false ->
|
2015-02-25 10:42:59 +01:00
|
|
|
HandlerModule:process(LocalPath, Request)
|
|
|
|
|
end,
|
|
|
|
|
ejabberd_hooks:run(http_request_debug, [{LocalPath, Request}]),
|
|
|
|
|
R;
|
|
|
|
|
false ->
|
2018-05-14 18:30:21 +02:00
|
|
|
process(HandlersLeft, Request)
|
2004-03-02 22:16:55 +01:00
|
|
|
end.
|
|
|
|
|
|
2015-02-25 10:42:59 +01:00
|
|
|
extract_path_query(#state{request_method = Method,
|
2015-11-12 17:23:39 +01:00
|
|
|
request_path = {abs_path, Path}} = State)
|
2015-02-25 10:42:59 +01:00
|
|
|
when Method =:= 'GET' orelse
|
|
|
|
|
Method =:= 'HEAD' orelse
|
|
|
|
|
Method =:= 'DELETE' orelse Method =:= 'OPTIONS' ->
|
2018-11-16 11:43:11 +01:00
|
|
|
case catch url_decode_q_split_normalize(Path) of
|
|
|
|
|
{'EXIT', Error} ->
|
|
|
|
|
?DEBUG("Error decoding URL '~p': ~p", [Path, Error]),
|
|
|
|
|
{State, false};
|
|
|
|
|
{LPath, Query} ->
|
2015-11-12 17:23:39 +01:00
|
|
|
LQuery = case catch parse_urlencoded(Query) of
|
|
|
|
|
{'EXIT', _Reason} -> [];
|
|
|
|
|
LQ -> LQ
|
|
|
|
|
end,
|
2020-03-26 14:17:48 +01:00
|
|
|
{State, {LPath, LQuery, <<"">>, Path}}
|
2015-02-25 10:42:59 +01:00
|
|
|
end;
|
|
|
|
|
extract_path_query(#state{request_method = Method,
|
|
|
|
|
request_path = {abs_path, Path},
|
|
|
|
|
request_content_length = Len,
|
2018-05-14 18:30:21 +02:00
|
|
|
trail = Trail,
|
2015-02-25 10:42:59 +01:00
|
|
|
sockmod = _SockMod,
|
|
|
|
|
socket = _Socket} = State)
|
2018-05-14 18:30:21 +02:00
|
|
|
when (Method =:= 'POST' orelse Method =:= 'PUT') andalso Len>0 ->
|
2018-11-16 11:43:11 +01:00
|
|
|
case catch url_decode_q_split_normalize(Path) of
|
|
|
|
|
{'EXIT', Error} ->
|
|
|
|
|
?DEBUG("Error decoding URL '~p': ~p", [Path, Error]),
|
|
|
|
|
{State, false};
|
|
|
|
|
{LPath, _Query} ->
|
2018-05-14 18:30:21 +02:00
|
|
|
case Method of
|
|
|
|
|
'PUT' ->
|
2020-03-26 14:17:48 +01:00
|
|
|
{State, {LPath, [], Trail, Path}};
|
2018-05-14 18:30:21 +02:00
|
|
|
'POST' ->
|
|
|
|
|
case recv_data(State) of
|
|
|
|
|
{ok, Data} ->
|
|
|
|
|
LQuery = case catch parse_urlencoded(Data) of
|
|
|
|
|
{'EXIT', _Reason} -> [];
|
|
|
|
|
LQ -> LQ
|
|
|
|
|
end,
|
2020-03-26 14:17:48 +01:00
|
|
|
{State, {LPath, LQuery, Data, Path}};
|
2018-05-14 18:30:21 +02:00
|
|
|
error ->
|
|
|
|
|
{State, false}
|
|
|
|
|
end
|
2016-09-27 23:22:30 +02:00
|
|
|
end
|
2015-02-25 10:42:59 +01:00
|
|
|
end;
|
2015-11-12 17:23:39 +01:00
|
|
|
extract_path_query(State) ->
|
|
|
|
|
{State, false}.
|
2015-02-25 10:42:59 +01:00
|
|
|
|
2017-10-11 17:53:53 +02:00
|
|
|
process_request(#state{request_host = undefined,
|
|
|
|
|
custom_headers = CustomHeaders} = State) ->
|
|
|
|
|
{State, make_text_output(State, 400, CustomHeaders,
|
|
|
|
|
<<"Missing Host header">>)};
|
2019-06-23 12:12:00 +02:00
|
|
|
process_request(#state{request_host = error,
|
|
|
|
|
custom_headers = CustomHeaders} = State) ->
|
|
|
|
|
{State, make_text_output(State, 400, CustomHeaders,
|
|
|
|
|
<<"Malformed Host header">>)};
|
2015-02-25 10:42:59 +01:00
|
|
|
process_request(#state{request_method = Method,
|
2015-10-07 00:06:58 +02:00
|
|
|
request_auth = Auth,
|
|
|
|
|
request_lang = Lang,
|
2018-05-23 14:52:47 +02:00
|
|
|
request_version = Version,
|
2015-10-07 00:06:58 +02:00
|
|
|
sockmod = SockMod,
|
|
|
|
|
socket = Socket,
|
2018-12-04 14:22:18 +01:00
|
|
|
sock_peer_name = SockPeer,
|
2015-10-07 00:06:58 +02:00
|
|
|
options = Options,
|
|
|
|
|
request_host = Host,
|
|
|
|
|
request_port = Port,
|
|
|
|
|
request_tp = TP,
|
2018-05-14 18:30:21 +02:00
|
|
|
request_content_length = Length,
|
2015-10-07 00:06:58 +02:00
|
|
|
request_headers = RequestHeaders,
|
|
|
|
|
request_handlers = RequestHandlers,
|
2018-05-14 18:30:21 +02:00
|
|
|
custom_headers = CustomHeaders} = State) ->
|
2018-05-23 14:52:47 +02:00
|
|
|
case proplists:get_value(<<"Expect">>, RequestHeaders, <<>>) of
|
|
|
|
|
<<"100-", _/binary>> when Version == {1, 1} ->
|
|
|
|
|
send_text(State, <<"HTTP/1.1 100 Continue\r\n\r\n">>);
|
|
|
|
|
_ ->
|
|
|
|
|
ok
|
|
|
|
|
end,
|
2015-02-25 10:42:59 +01:00
|
|
|
case extract_path_query(State) of
|
2015-11-12 17:23:39 +01:00
|
|
|
{State2, false} ->
|
|
|
|
|
{State2, make_bad_request(State)};
|
2020-03-26 14:17:48 +01:00
|
|
|
{State2, {LPath, LQuery, Data, RawPath}} ->
|
2018-12-04 14:22:18 +01:00
|
|
|
PeerName = case SockPeer of
|
|
|
|
|
none ->
|
|
|
|
|
case SockMod of
|
|
|
|
|
gen_tcp ->
|
|
|
|
|
inet:peername(Socket);
|
|
|
|
|
_ ->
|
|
|
|
|
SockMod:peername(Socket)
|
|
|
|
|
end;
|
|
|
|
|
{_, Peer} ->
|
|
|
|
|
{ok, Peer}
|
|
|
|
|
end,
|
2015-08-17 15:50:02 +02:00
|
|
|
IPHere = case PeerName of
|
|
|
|
|
{ok, V} -> V;
|
|
|
|
|
{error, _} = E -> throw(E)
|
|
|
|
|
end,
|
2010-12-07 16:47:32 +01:00
|
|
|
XFF = proplists:get_value('X-Forwarded-For', RequestHeaders, []),
|
2019-08-13 17:30:28 +02:00
|
|
|
IP = analyze_ip_xff(IPHere, XFF),
|
2015-02-25 10:42:59 +01:00
|
|
|
Request = #request{method = Method,
|
|
|
|
|
path = LPath,
|
2020-03-26 14:17:48 +01:00
|
|
|
raw_path = RawPath,
|
2015-02-25 10:42:59 +01:00
|
|
|
q = LQuery,
|
|
|
|
|
auth = Auth,
|
2018-05-14 18:30:21 +02:00
|
|
|
length = Length,
|
|
|
|
|
sockmod = SockMod,
|
|
|
|
|
socket = Socket,
|
|
|
|
|
data = Data,
|
2015-02-25 10:42:59 +01:00
|
|
|
lang = Lang,
|
|
|
|
|
host = Host,
|
|
|
|
|
port = Port,
|
|
|
|
|
tp = TP,
|
2014-10-03 16:53:55 +02:00
|
|
|
opts = Options,
|
2015-02-25 10:42:59 +01:00
|
|
|
headers = RequestHeaders,
|
|
|
|
|
ip = IP},
|
2017-11-15 08:01:30 +01:00
|
|
|
RequestHandlers1 = ejabberd_hooks:run_fold(
|
|
|
|
|
http_request_handlers, RequestHandlers, [Host, Request]),
|
2018-05-14 18:30:21 +02:00
|
|
|
Res = case process(RequestHandlers1, Request) of
|
2015-11-12 17:23:39 +01:00
|
|
|
El when is_record(El, xmlel) ->
|
2017-03-27 23:19:11 +02:00
|
|
|
make_xhtml_output(State, 200, CustomHeaders, El);
|
2015-11-12 17:23:39 +01:00
|
|
|
{Status, Headers, El}
|
|
|
|
|
when is_record(El, xmlel) ->
|
2017-03-27 23:19:11 +02:00
|
|
|
make_xhtml_output(State, Status,
|
2020-02-21 12:19:02 +01:00
|
|
|
apply_custom_headers(Headers, CustomHeaders), El);
|
2015-11-12 17:23:39 +01:00
|
|
|
Output when is_binary(Output) or is_list(Output) ->
|
2017-03-27 23:19:11 +02:00
|
|
|
make_text_output(State, 200, CustomHeaders, Output);
|
2015-11-12 17:23:39 +01:00
|
|
|
{Status, Headers, Output}
|
|
|
|
|
when is_binary(Output) or is_list(Output) ->
|
2017-03-27 23:19:11 +02:00
|
|
|
make_text_output(State, Status,
|
2020-02-21 12:19:02 +01:00
|
|
|
apply_custom_headers(Headers, CustomHeaders), Output);
|
2018-05-14 18:30:21 +02:00
|
|
|
{Status, Headers, {file, FileName}} ->
|
|
|
|
|
make_file_output(State, Status, Headers, FileName);
|
2015-11-12 17:23:39 +01:00
|
|
|
{Status, Reason, Headers, Output}
|
|
|
|
|
when is_binary(Output) or is_list(Output) ->
|
2017-03-27 23:19:11 +02:00
|
|
|
make_text_output(State, Status, Reason,
|
2020-02-21 12:19:02 +01:00
|
|
|
apply_custom_headers(Headers, CustomHeaders), Output);
|
2015-11-12 17:23:39 +01:00
|
|
|
_ ->
|
|
|
|
|
none
|
|
|
|
|
end,
|
2018-05-15 14:25:19 +02:00
|
|
|
{State2#state{trail = <<>>}, Res}
|
2015-02-25 10:42:59 +01:00
|
|
|
end.
|
2011-09-05 08:31:58 +02:00
|
|
|
|
|
|
|
|
make_bad_request(State) ->
|
2017-03-27 23:19:11 +02:00
|
|
|
make_xhtml_output(State, 400, State#state.custom_headers,
|
2013-03-14 10:33:02 +01:00
|
|
|
ejabberd_web:make_xhtml([#xmlel{name = <<"h1">>,
|
|
|
|
|
attrs = [],
|
|
|
|
|
children =
|
|
|
|
|
[{xmlcdata,
|
|
|
|
|
<<"400 Bad Request">>}]}])).
|
|
|
|
|
|
2019-08-13 17:30:28 +02:00
|
|
|
analyze_ip_xff(IP, []) -> IP;
|
|
|
|
|
analyze_ip_xff({IPLast, Port}, XFF) ->
|
2013-03-14 10:33:02 +01:00
|
|
|
[ClientIP | ProxiesIPs] = str:tokens(XFF, <<", ">>) ++
|
2017-04-11 12:13:58 +02:00
|
|
|
[misc:ip_to_list(IPLast)],
|
2019-08-13 17:30:28 +02:00
|
|
|
TrustedProxies = ejabberd_option:trusted_proxies(),
|
2013-03-14 10:33:02 +01:00
|
|
|
IPClient = case is_ipchain_trusted(ProxiesIPs,
|
|
|
|
|
TrustedProxies)
|
|
|
|
|
of
|
|
|
|
|
true ->
|
|
|
|
|
{ok, IPFirst} = inet_parse:address(
|
|
|
|
|
binary_to_list(ClientIP)),
|
|
|
|
|
?DEBUG("The IP ~w was replaced with ~w due to "
|
2019-09-23 14:17:20 +02:00
|
|
|
"header X-Forwarded-For: ~ts",
|
2013-03-14 10:33:02 +01:00
|
|
|
[IPLast, IPFirst, XFF]),
|
|
|
|
|
IPFirst;
|
|
|
|
|
false -> IPLast
|
2010-12-07 16:47:32 +01:00
|
|
|
end,
|
|
|
|
|
{IPClient, Port}.
|
2013-03-14 10:33:02 +01:00
|
|
|
|
2018-05-04 09:53:07 +02:00
|
|
|
is_ipchain_trusted([], _) -> false;
|
2013-03-14 10:33:02 +01:00
|
|
|
is_ipchain_trusted(_UserIPs, all) -> true;
|
2018-05-04 09:53:07 +02:00
|
|
|
is_ipchain_trusted(UserIPs, Masks) ->
|
|
|
|
|
lists:all(
|
|
|
|
|
fun(IP) ->
|
|
|
|
|
case inet:parse_address(binary_to_list(IP)) of
|
|
|
|
|
{ok, IP2} ->
|
|
|
|
|
lists:any(
|
|
|
|
|
fun({Mask, MaskLen}) ->
|
2019-06-14 11:33:26 +02:00
|
|
|
misc:match_ip_mask(IP2, Mask, MaskLen)
|
2018-10-24 15:16:32 +02:00
|
|
|
end, Masks);
|
2018-05-04 09:53:07 +02:00
|
|
|
_ ->
|
|
|
|
|
false
|
|
|
|
|
end
|
|
|
|
|
end, UserIPs).
|
2004-03-02 22:16:55 +01:00
|
|
|
|
2018-05-14 18:30:21 +02:00
|
|
|
recv_data(#state{request_content_length = Len}) when Len >= ?MAX_POST_SIZE ->
|
|
|
|
|
error;
|
|
|
|
|
recv_data(#state{request_content_length = Len, trail = Trail,
|
|
|
|
|
sockmod = SockMod, socket = Socket}) ->
|
|
|
|
|
NewLen = Len - byte_size(Trail),
|
|
|
|
|
if NewLen > 0 ->
|
|
|
|
|
case SockMod:recv(Socket, NewLen, 60000) of
|
|
|
|
|
{ok, Data} -> {ok, <<Trail/binary, Data/binary>>};
|
|
|
|
|
{error, _} -> error
|
2015-11-12 17:23:39 +01:00
|
|
|
end;
|
2018-05-14 18:30:21 +02:00
|
|
|
true ->
|
|
|
|
|
{ok, Trail}
|
2004-03-02 22:16:55 +01:00
|
|
|
end.
|
|
|
|
|
|
2018-05-14 18:30:21 +02:00
|
|
|
recv_file(#request{length = Len, data = Trail,
|
|
|
|
|
sockmod = SockMod, socket = Socket}, Path) ->
|
|
|
|
|
case file:open(Path, [write, exclusive, raw]) of
|
|
|
|
|
{ok, Fd} ->
|
2018-07-04 07:55:52 +02:00
|
|
|
Res = case file:write(Fd, Trail) of
|
|
|
|
|
ok ->
|
|
|
|
|
NewLen = max(0, Len - byte_size(Trail)),
|
|
|
|
|
do_recv_file(NewLen, SockMod, Socket, Fd);
|
|
|
|
|
{error, _} = Err ->
|
|
|
|
|
Err
|
|
|
|
|
end,
|
|
|
|
|
file:close(Fd),
|
|
|
|
|
case Res of
|
|
|
|
|
ok -> ok;
|
|
|
|
|
{error, _} -> file:delete(Path)
|
|
|
|
|
end,
|
|
|
|
|
Res;
|
2018-05-14 18:30:21 +02:00
|
|
|
{error, _} = Err ->
|
|
|
|
|
Err
|
|
|
|
|
end.
|
2013-03-14 10:33:02 +01:00
|
|
|
|
2018-07-04 07:55:52 +02:00
|
|
|
do_recv_file(0, _SockMod, _Socket, _Fd) ->
|
|
|
|
|
ok;
|
2018-05-14 18:30:21 +02:00
|
|
|
do_recv_file(Len, SockMod, Socket, Fd) ->
|
|
|
|
|
ChunkLen = min(Len, ?RECV_BUF),
|
2018-07-04 07:55:52 +02:00
|
|
|
case SockMod:recv(Socket, ChunkLen, timer:seconds(30)) of
|
|
|
|
|
{ok, Data} ->
|
|
|
|
|
case file:write(Fd, Data) of
|
|
|
|
|
ok ->
|
|
|
|
|
do_recv_file(Len-size(Data), SockMod, Socket, Fd);
|
|
|
|
|
{error, _} = Err ->
|
|
|
|
|
Err
|
|
|
|
|
end;
|
|
|
|
|
{error, _} ->
|
|
|
|
|
{error, closed}
|
2018-05-14 18:30:21 +02:00
|
|
|
end.
|
2013-03-14 10:33:02 +01:00
|
|
|
|
2018-05-14 18:30:21 +02:00
|
|
|
make_headers(State, Status, Reason, Headers, Data) ->
|
|
|
|
|
Len = if is_integer(Data) -> Data;
|
|
|
|
|
true -> iolist_size(Data)
|
|
|
|
|
end,
|
|
|
|
|
Headers1 = [{<<"Content-Length">>, integer_to_binary(Len)} | Headers],
|
|
|
|
|
Headers2 = case lists:keyfind(<<"Content-Type">>, 1, Headers) of
|
|
|
|
|
{_, _} ->
|
|
|
|
|
Headers1;
|
|
|
|
|
false ->
|
|
|
|
|
[{<<"Content-Type">>, <<"text/html; charset=utf-8">>}
|
|
|
|
|
| Headers1]
|
2004-03-13 21:01:37 +01:00
|
|
|
end,
|
2005-05-23 01:29:54 +02:00
|
|
|
HeadersOut = case {State#state.request_version,
|
2018-05-14 18:30:21 +02:00
|
|
|
State#state.request_keepalive} of
|
|
|
|
|
{{1, 1}, true} -> Headers2;
|
|
|
|
|
{_, true} ->
|
|
|
|
|
[{<<"Connection">>, <<"keep-alive">>} | Headers2];
|
|
|
|
|
{_, false} ->
|
|
|
|
|
[{<<"Connection">>, <<"close">>} | Headers2]
|
2005-05-23 01:29:54 +02:00
|
|
|
end,
|
|
|
|
|
Version = case State#state.request_version of
|
2018-05-14 18:30:21 +02:00
|
|
|
{1, 1} -> <<"HTTP/1.1 ">>;
|
|
|
|
|
_ -> <<"HTTP/1.0 ">>
|
2005-05-23 01:29:54 +02:00
|
|
|
end,
|
2018-05-14 18:30:21 +02:00
|
|
|
H = [[Attr, <<": ">>, Val, <<"\r\n">>] || {Attr, Val} <- HeadersOut],
|
2013-03-14 10:33:02 +01:00
|
|
|
NewReason = case Reason of
|
|
|
|
|
<<"">> -> code_to_phrase(Status);
|
|
|
|
|
_ -> Reason
|
|
|
|
|
end,
|
|
|
|
|
SL = [Version,
|
2016-09-24 22:34:28 +02:00
|
|
|
integer_to_binary(Status), <<" ">>,
|
2013-03-14 10:33:02 +01:00
|
|
|
NewReason, <<"\r\n">>],
|
2018-05-14 18:30:21 +02:00
|
|
|
[SL, H, <<"\r\n">>].
|
|
|
|
|
|
|
|
|
|
make_xhtml_output(State, Status, Headers, XHTML) ->
|
|
|
|
|
Data = case State#state.request_method of
|
|
|
|
|
'HEAD' -> <<"">>;
|
|
|
|
|
_ ->
|
|
|
|
|
DocType = case lists:member(html, Headers) of
|
|
|
|
|
true -> ?HTML_DOCTYPE;
|
|
|
|
|
false -> ?XHTML_DOCTYPE
|
|
|
|
|
end,
|
|
|
|
|
iolist_to_binary([DocType, fxml:element_to_binary(XHTML)])
|
|
|
|
|
end,
|
|
|
|
|
EncodedHdrs = make_headers(State, Status, <<"">>, Headers, Data),
|
|
|
|
|
[EncodedHdrs, Data].
|
|
|
|
|
|
|
|
|
|
make_text_output(State, Status, Headers, Text) ->
|
|
|
|
|
make_text_output(State, Status, <<"">>, Headers, Text).
|
|
|
|
|
|
|
|
|
|
make_text_output(State, Status, Reason, Headers, Text) ->
|
|
|
|
|
Data = iolist_to_binary(Text),
|
2011-04-12 23:31:08 +02:00
|
|
|
Data2 = case State#state.request_method of
|
2018-05-14 18:30:21 +02:00
|
|
|
'HEAD' -> <<"">>;
|
|
|
|
|
_ -> Data
|
2013-03-14 10:33:02 +01:00
|
|
|
end,
|
2018-05-14 18:30:21 +02:00
|
|
|
EncodedHdrs = make_headers(State, Status, Reason, Headers, Data2),
|
|
|
|
|
[EncodedHdrs, Data2].
|
|
|
|
|
|
|
|
|
|
make_file_output(State, Status, Headers, FileName) ->
|
|
|
|
|
case file:read_file_info(FileName) of
|
|
|
|
|
{ok, #file_info{size = Size}} when State#state.request_method == 'HEAD' ->
|
|
|
|
|
make_headers(State, Status, <<"">>, Headers, Size);
|
|
|
|
|
{ok, #file_info{size = Size}} ->
|
|
|
|
|
case file:open(FileName, [raw, read]) of
|
|
|
|
|
{ok, Fd} ->
|
|
|
|
|
EncodedHdrs = make_headers(State, Status, <<"">>, Headers, Size),
|
|
|
|
|
send_text(State, EncodedHdrs),
|
|
|
|
|
send_file(State, Fd, Size, FileName),
|
|
|
|
|
file:close(Fd),
|
|
|
|
|
none;
|
|
|
|
|
{error, Why} ->
|
|
|
|
|
Reason = file_format_error(Why),
|
2019-09-23 14:17:20 +02:00
|
|
|
?ERROR_MSG("Failed to open ~ts: ~ts", [FileName, Reason]),
|
2018-05-14 18:30:21 +02:00
|
|
|
make_text_output(State, 404, Reason, [], <<>>)
|
|
|
|
|
end;
|
|
|
|
|
{error, Why} ->
|
|
|
|
|
Reason = file_format_error(Why),
|
2019-09-23 14:17:20 +02:00
|
|
|
?ERROR_MSG("Failed to read info of ~ts: ~ts", [FileName, Reason]),
|
2018-05-14 18:30:21 +02:00
|
|
|
make_text_output(State, 404, Reason, [], <<>>)
|
|
|
|
|
end.
|
2004-03-02 22:16:55 +01:00
|
|
|
|
2004-05-01 22:10:25 +02:00
|
|
|
parse_lang(Langs) ->
|
2013-03-14 10:33:02 +01:00
|
|
|
case str:tokens(Langs, <<",; ">>) of
|
|
|
|
|
[First | _] -> First;
|
|
|
|
|
[] -> <<"en">>
|
2004-05-01 22:10:25 +02:00
|
|
|
end.
|
|
|
|
|
|
2018-05-14 18:30:21 +02:00
|
|
|
file_format_error(Reason) ->
|
|
|
|
|
case file:format_error(Reason) of
|
|
|
|
|
"unknown POSIX error" -> atom_to_list(Reason);
|
|
|
|
|
Text -> Text
|
|
|
|
|
end.
|
|
|
|
|
|
2018-11-16 11:43:11 +01:00
|
|
|
url_decode_q_split_normalize(Path) ->
|
|
|
|
|
{NPath, Query} = url_decode_q_split(Path),
|
|
|
|
|
LPath = normalize_path([NPE
|
|
|
|
|
|| NPE <- str:tokens(path_decode(NPath), <<"/">>)]),
|
|
|
|
|
{LPath, Query}.
|
|
|
|
|
|
2004-03-02 22:16:55 +01:00
|
|
|
% Code below is taken (with some modifications) from the yaws webserver, which
|
2018-01-27 17:35:38 +01:00
|
|
|
% is distributed under the following license:
|
2004-03-02 22:16:55 +01:00
|
|
|
%
|
|
|
|
|
% This software (the yaws webserver) is free software.
|
|
|
|
|
% Parts of this software is Copyright (c) Claes Wikstrom <klacke@hyber.org>
|
|
|
|
|
% Any use or misuse of the source code is hereby freely allowed.
|
|
|
|
|
%
|
|
|
|
|
% 1. Redistributions of source code must retain the above copyright
|
|
|
|
|
% notice as well as this list of conditions.
|
|
|
|
|
%
|
|
|
|
|
% 2. Redistributions in binary form must reproduce the above copyright
|
|
|
|
|
% notice as well as this list of conditions.
|
|
|
|
|
|
2008-11-12 11:03:27 +01:00
|
|
|
%% @doc Split the URL and return {Path, QueryPart}
|
2004-03-02 22:16:55 +01:00
|
|
|
url_decode_q_split(Path) ->
|
2013-03-14 10:33:02 +01:00
|
|
|
url_decode_q_split(Path, <<>>).
|
|
|
|
|
|
|
|
|
|
url_decode_q_split(<<$?, T/binary>>, Acc) ->
|
2004-03-02 22:16:55 +01:00
|
|
|
%% Don't decode the query string here, that is parsed separately.
|
2013-03-14 10:33:02 +01:00
|
|
|
{path_norm_reverse(Acc), T};
|
|
|
|
|
url_decode_q_split(<<H, T/binary>>, Acc) when H /= 0 ->
|
|
|
|
|
url_decode_q_split(T, <<H, Acc/binary>>);
|
|
|
|
|
url_decode_q_split(<<>>, Ack) ->
|
|
|
|
|
{path_norm_reverse(Ack), <<>>}.
|
2004-03-02 22:16:55 +01:00
|
|
|
|
2008-11-12 11:03:27 +01:00
|
|
|
%% @doc Decode a part of the URL and return string()
|
2013-03-14 10:33:02 +01:00
|
|
|
path_decode(Path) -> path_decode(Path, <<>>).
|
|
|
|
|
|
|
|
|
|
path_decode(<<$%, Hi, Lo, Tail/binary>>, Acc) ->
|
2018-04-03 00:21:33 +02:00
|
|
|
Hex = list_to_integer([Hi, Lo], 16),
|
2013-03-14 10:33:02 +01:00
|
|
|
if Hex == 0 -> exit(badurl);
|
2008-11-12 11:03:27 +01:00
|
|
|
true -> ok
|
|
|
|
|
end,
|
2013-03-14 10:33:02 +01:00
|
|
|
path_decode(Tail, <<Acc/binary, Hex>>);
|
|
|
|
|
path_decode(<<H, T/binary>>, Acc) when H /= 0 ->
|
|
|
|
|
path_decode(T, <<Acc/binary, H>>);
|
|
|
|
|
path_decode(<<>>, Acc) -> Acc.
|
|
|
|
|
|
|
|
|
|
path_norm_reverse(<<"/", T/binary>>) -> start_dir(0, <<"/">>, T);
|
|
|
|
|
path_norm_reverse(T) -> start_dir(0, <<"">>, T).
|
|
|
|
|
|
|
|
|
|
start_dir(N, Path, <<"..">>) -> rest_dir(N, Path, <<"">>);
|
|
|
|
|
start_dir(N, Path, <<"/", T/binary>>) -> start_dir(N, Path, T);
|
|
|
|
|
start_dir(N, Path, <<"./", T/binary>>) -> start_dir(N, Path, T);
|
|
|
|
|
start_dir(N, Path, <<"../", T/binary>>) ->
|
|
|
|
|
start_dir(N + 1, Path, T);
|
|
|
|
|
start_dir(N, Path, T) -> rest_dir(N, Path, T).
|
|
|
|
|
|
|
|
|
|
rest_dir(_N, Path, <<>>) ->
|
|
|
|
|
case Path of
|
|
|
|
|
<<>> -> <<"/">>;
|
|
|
|
|
_ -> Path
|
|
|
|
|
end;
|
|
|
|
|
rest_dir(0, Path, <<$/, T/binary>>) ->
|
|
|
|
|
start_dir(0, <<$/, Path/binary>>, T);
|
|
|
|
|
rest_dir(N, Path, <<$/, T/binary>>) ->
|
|
|
|
|
start_dir(N - 1, Path, T);
|
|
|
|
|
rest_dir(0, Path, <<H, T/binary>>) ->
|
|
|
|
|
rest_dir(0, <<H, Path/binary>>, T);
|
|
|
|
|
rest_dir(N, Path, <<_H, T/binary>>) -> rest_dir(N, Path, T).
|
2004-03-02 22:16:55 +01:00
|
|
|
|
2013-03-14 10:33:02 +01:00
|
|
|
code_to_phrase(100) -> <<"Continue">>;
|
|
|
|
|
code_to_phrase(101) -> <<"Switching Protocols ">>;
|
|
|
|
|
code_to_phrase(200) -> <<"OK">>;
|
|
|
|
|
code_to_phrase(201) -> <<"Created">>;
|
|
|
|
|
code_to_phrase(202) -> <<"Accepted">>;
|
|
|
|
|
code_to_phrase(203) ->
|
|
|
|
|
<<"Non-Authoritative Information">>;
|
|
|
|
|
code_to_phrase(204) -> <<"No Content">>;
|
|
|
|
|
code_to_phrase(205) -> <<"Reset Content">>;
|
|
|
|
|
code_to_phrase(206) -> <<"Partial Content">>;
|
|
|
|
|
code_to_phrase(300) -> <<"Multiple Choices">>;
|
|
|
|
|
code_to_phrase(301) -> <<"Moved Permanently">>;
|
|
|
|
|
code_to_phrase(302) -> <<"Found">>;
|
|
|
|
|
code_to_phrase(303) -> <<"See Other">>;
|
|
|
|
|
code_to_phrase(304) -> <<"Not Modified">>;
|
|
|
|
|
code_to_phrase(305) -> <<"Use Proxy">>;
|
|
|
|
|
code_to_phrase(306) -> <<"(Unused)">>;
|
|
|
|
|
code_to_phrase(307) -> <<"Temporary Redirect">>;
|
|
|
|
|
code_to_phrase(400) -> <<"Bad Request">>;
|
|
|
|
|
code_to_phrase(401) -> <<"Unauthorized">>;
|
|
|
|
|
code_to_phrase(402) -> <<"Payment Required">>;
|
|
|
|
|
code_to_phrase(403) -> <<"Forbidden">>;
|
|
|
|
|
code_to_phrase(404) -> <<"Not Found">>;
|
|
|
|
|
code_to_phrase(405) -> <<"Method Not Allowed">>;
|
|
|
|
|
code_to_phrase(406) -> <<"Not Acceptable">>;
|
|
|
|
|
code_to_phrase(407) ->
|
|
|
|
|
<<"Proxy Authentication Required">>;
|
|
|
|
|
code_to_phrase(408) -> <<"Request Timeout">>;
|
|
|
|
|
code_to_phrase(409) -> <<"Conflict">>;
|
|
|
|
|
code_to_phrase(410) -> <<"Gone">>;
|
|
|
|
|
code_to_phrase(411) -> <<"Length Required">>;
|
|
|
|
|
code_to_phrase(412) -> <<"Precondition Failed">>;
|
|
|
|
|
code_to_phrase(413) -> <<"Request Entity Too Large">>;
|
|
|
|
|
code_to_phrase(414) -> <<"Request-URI Too Long">>;
|
|
|
|
|
code_to_phrase(415) -> <<"Unsupported Media Type">>;
|
|
|
|
|
code_to_phrase(416) ->
|
|
|
|
|
<<"Requested Range Not Satisfiable">>;
|
|
|
|
|
code_to_phrase(417) -> <<"Expectation Failed">>;
|
|
|
|
|
code_to_phrase(500) -> <<"Internal Server Error">>;
|
|
|
|
|
code_to_phrase(501) -> <<"Not Implemented">>;
|
|
|
|
|
code_to_phrase(502) -> <<"Bad Gateway">>;
|
|
|
|
|
code_to_phrase(503) -> <<"Service Unavailable">>;
|
|
|
|
|
code_to_phrase(504) -> <<"Gateway Timeout">>;
|
|
|
|
|
code_to_phrase(505) -> <<"HTTP Version Not Supported">>.
|
|
|
|
|
|
2019-06-14 11:33:26 +02:00
|
|
|
-spec parse_auth(binary()) -> {binary(), binary()} | {oauth, binary(), []} | invalid.
|
2013-03-14 10:33:02 +01:00
|
|
|
parse_auth(<<"Basic ", Auth64/binary>>) ->
|
2019-01-30 16:34:29 +01:00
|
|
|
try base64:decode(Auth64) of
|
|
|
|
|
Auth ->
|
|
|
|
|
case binary:split(Auth, <<":">>) of
|
|
|
|
|
[User, Pass] ->
|
|
|
|
|
PassUtf8 = unicode:characters_to_binary(Pass, utf8),
|
|
|
|
|
{User, PassUtf8};
|
|
|
|
|
_ ->
|
|
|
|
|
invalid
|
|
|
|
|
end
|
|
|
|
|
catch _:_ ->
|
|
|
|
|
invalid
|
2004-03-02 22:16:55 +01:00
|
|
|
end;
|
2015-09-25 14:53:25 +02:00
|
|
|
parse_auth(<<"Bearer ", SToken/binary>>) ->
|
|
|
|
|
Token = str:strip(SToken),
|
|
|
|
|
{oauth, Token, []};
|
2019-01-30 16:34:29 +01:00
|
|
|
parse_auth(<<_/binary>>) ->
|
|
|
|
|
invalid.
|
2004-03-02 22:16:55 +01:00
|
|
|
|
|
|
|
|
parse_urlencoded(S) ->
|
2013-03-14 10:33:02 +01:00
|
|
|
parse_urlencoded(S, nokey, <<>>, key).
|
2004-03-02 22:16:55 +01:00
|
|
|
|
2013-03-14 10:33:02 +01:00
|
|
|
parse_urlencoded(<<$%, Hi, Lo, Tail/binary>>, Last, Cur,
|
|
|
|
|
State) ->
|
2018-04-03 00:21:33 +02:00
|
|
|
Hex = list_to_integer([Hi, Lo], 16),
|
2013-03-14 10:33:02 +01:00
|
|
|
parse_urlencoded(Tail, Last, <<Cur/binary, Hex>>, State);
|
|
|
|
|
parse_urlencoded(<<$&, Tail/binary>>, _Last, Cur, key) ->
|
|
|
|
|
[{Cur, <<"">>} | parse_urlencoded(Tail,
|
|
|
|
|
nokey, <<>>,
|
|
|
|
|
key)]; %% cont keymode
|
|
|
|
|
parse_urlencoded(<<$&, Tail/binary>>, Last, Cur, value) ->
|
|
|
|
|
V = {Last, Cur},
|
|
|
|
|
[V | parse_urlencoded(Tail, nokey, <<>>, key)];
|
|
|
|
|
parse_urlencoded(<<$+, Tail/binary>>, Last, Cur, State) ->
|
|
|
|
|
parse_urlencoded(Tail, Last, <<Cur/binary, $\s>>, State);
|
|
|
|
|
parse_urlencoded(<<$=, Tail/binary>>, _Last, Cur, key) ->
|
|
|
|
|
parse_urlencoded(Tail, Cur, <<>>,
|
|
|
|
|
value); %% change mode
|
|
|
|
|
parse_urlencoded(<<H, Tail/binary>>, Last, Cur, State) ->
|
|
|
|
|
parse_urlencoded(Tail, Last, <<Cur/binary, H>>, State);
|
|
|
|
|
parse_urlencoded(<<>>, Last, Cur, _State) ->
|
|
|
|
|
[{Last, Cur}];
|
|
|
|
|
parse_urlencoded(undefined, _, _, _) -> [].
|
|
|
|
|
|
2020-02-21 12:19:02 +01:00
|
|
|
apply_custom_headers(Headers, CustomHeaders) ->
|
2020-02-26 13:35:47 +01:00
|
|
|
{Doctype, Headers2} = case Headers -- [html] of
|
|
|
|
|
Headers -> {[], Headers};
|
|
|
|
|
Other -> {[html], Other}
|
|
|
|
|
end,
|
|
|
|
|
M = maps:merge(maps:from_list(Headers2),
|
2020-02-21 12:19:02 +01:00
|
|
|
maps:from_list(CustomHeaders)),
|
2020-02-26 13:35:47 +01:00
|
|
|
Doctype ++ maps:to_list(M).
|
2020-02-21 12:19:02 +01:00
|
|
|
|
2015-02-25 14:36:48 +01:00
|
|
|
% The following code is mostly taken from yaws_ssl.erl
|
|
|
|
|
|
|
|
|
|
toupper(C) when C >= $a andalso C =< $z -> C - 32;
|
|
|
|
|
toupper(C) -> C.
|
|
|
|
|
|
|
|
|
|
tolower(C) when C >= $A andalso C =< $Z -> C + 32;
|
|
|
|
|
tolower(C) -> C.
|
|
|
|
|
|
|
|
|
|
normalize_header_name(Name) ->
|
|
|
|
|
normalize_header_name(Name, [], true).
|
|
|
|
|
|
|
|
|
|
normalize_header_name(<<"">>, Acc, _) ->
|
|
|
|
|
iolist_to_binary(Acc);
|
|
|
|
|
normalize_header_name(<<"-", Rest/binary>>, Acc, _) ->
|
|
|
|
|
normalize_header_name(Rest, [Acc, "-"], true);
|
|
|
|
|
normalize_header_name(<<C:8, Rest/binary>>, Acc, true) ->
|
|
|
|
|
normalize_header_name(Rest, [Acc, toupper(C)], false);
|
|
|
|
|
normalize_header_name(<<C:8, Rest/binary>>, Acc, false) ->
|
|
|
|
|
normalize_header_name(Rest, [Acc, tolower(C)], false).
|
|
|
|
|
|
2013-06-25 11:26:44 +02:00
|
|
|
normalize_path(Path) ->
|
|
|
|
|
normalize_path(Path, []).
|
|
|
|
|
|
|
|
|
|
normalize_path([], Norm) -> lists:reverse(Norm);
|
2013-06-25 13:46:21 +02:00
|
|
|
normalize_path([<<"..">>|Path], Norm) ->
|
2013-06-25 11:26:44 +02:00
|
|
|
normalize_path(Path, Norm);
|
2013-06-25 13:46:21 +02:00
|
|
|
normalize_path([_Parent, <<"..">>|Path], Norm) ->
|
2013-06-25 11:26:44 +02:00
|
|
|
normalize_path(Path, Norm);
|
|
|
|
|
normalize_path([Part | Path], Norm) ->
|
|
|
|
|
normalize_path(Path, [Part|Norm]).
|
2013-08-12 14:25:05 +02:00
|
|
|
|
2019-01-30 12:56:52 +01:00
|
|
|
listen_opt_type(tag) ->
|
2019-06-14 11:33:26 +02:00
|
|
|
econf:binary();
|
2017-04-30 18:01:47 +02:00
|
|
|
listen_opt_type(request_handlers) ->
|
2019-07-15 08:59:07 +02:00
|
|
|
econf:map(
|
|
|
|
|
econf:and_then(
|
2019-06-14 11:33:26 +02:00
|
|
|
econf:binary(),
|
2019-07-15 08:59:07 +02:00
|
|
|
fun(Path) -> str:tokens(Path, <<"/">>) end),
|
|
|
|
|
econf:beam([[{socket_handoff, 3}, {process, 2}]]));
|
2017-04-30 18:01:47 +02:00
|
|
|
listen_opt_type(default_host) ->
|
2019-06-14 11:33:26 +02:00
|
|
|
econf:domain();
|
2017-04-30 18:01:47 +02:00
|
|
|
listen_opt_type(custom_headers) ->
|
2019-07-15 08:59:07 +02:00
|
|
|
econf:map(
|
|
|
|
|
econf:binary(),
|
|
|
|
|
econf:and_then(
|
2019-06-14 11:33:26 +02:00
|
|
|
econf:binary(),
|
2019-07-15 08:59:07 +02:00
|
|
|
fun(V) ->
|
|
|
|
|
misc:expand_keyword(<<"@VERSION@">>, V,
|
|
|
|
|
ejabberd_option:version())
|
|
|
|
|
end)).
|
2018-09-18 11:53:36 +02:00
|
|
|
|
|
|
|
|
listen_options() ->
|
2019-06-14 11:33:26 +02:00
|
|
|
[{ciphers, undefined},
|
2018-09-18 11:53:36 +02:00
|
|
|
{dhfile, undefined},
|
|
|
|
|
{cafile, undefined},
|
|
|
|
|
{protocol_options, undefined},
|
|
|
|
|
{tls, false},
|
|
|
|
|
{tls_compression, false},
|
|
|
|
|
{request_handlers, []},
|
2019-01-30 12:56:52 +01:00
|
|
|
{tag, <<>>},
|
2018-09-18 11:53:36 +02:00
|
|
|
{default_host, undefined},
|
|
|
|
|
{custom_headers, []}].
|
