2 * InspIRCd -- Internet Relay Chat Daemon
4 * Copyright (C) 2009 Daniel De Graaf <danieldg@inspircd.org>
5 * Copyright (C) 2007-2008 Robin Burchell <robin+git@viroteck.net>
6 * Copyright (C) 2008 Pippijn van Steenhoven <pip88nl@gmail.com>
7 * Copyright (C) 2006-2008 Craig Edwards <craigedwards@brainbox.cc>
8 * Copyright (C) 2007 John Brooks <john.brooks@dereferenced.net>
9 * Copyright (C) 2007 Dennis Friis <peavey@inspircd.org>
11 * This file is part of InspIRCd. InspIRCd is free software: you can
12 * redistribute it and/or modify it under the terms of the GNU General Public
13 * License as published by the Free Software Foundation, version 2.
15 * This program is distributed in the hope that it will be useful, but WITHOUT
16 * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS
17 * FOR A PARTICULAR PURPOSE. See the GNU General Public License for more
20 * You should have received a copy of the GNU General Public License
21 * along with this program. If not, see <http://www.gnu.org/licenses/>.
24 /// $CompilerFlags: -Ivendor_directory("http_parser")
29 #include "modules/httpd.h"
31 // Fix warnings about the use of commas at end of enumerator lists on C++03.
33 # pragma clang diagnostic ignored "-Wc++11-extensions"
34 #elif defined __GNUC__
35 # if (__GNUC__ > 4) || ((__GNUC__ == 4) && (__GNUC_MINOR__ >= 8))
36 # pragma GCC diagnostic ignored "-Wpedantic"
38 # pragma GCC diagnostic ignored "-pedantic"
42 // Fix warnings about shadowing in http_parser.
43 #pragma GCC diagnostic ignored "-Wshadow"
45 #include <http_parser.c>
47 class ModuleHttpServer;
49 static ModuleHttpServer* HttpModule;
50 static insp::intrusive_list<HttpServerSocket> sockets;
51 static Events::ModuleEventProvider* aclevprov;
52 static Events::ModuleEventProvider* reqevprov;
53 static http_parser_settings parser_settings;
55 /** A socket used for HTTP transport
57 class HttpServerSocket : public BufferedSocket, public Timer, public insp::intrusive_list_node<HttpServerSocket>
59 friend ModuleHttpServer;
70 /** True if this object is in the cull list
74 bool Tick(time_t currtime) CXX11_OVERRIDE
80 template<int (HttpServerSocket::*f)()>
81 static int Callback(http_parser* p)
83 HttpServerSocket* sock = static_cast<HttpServerSocket*>(p->data);
87 template<int (HttpServerSocket::*f)(const char*, size_t)>
88 static int DataCallback(http_parser* p, const char* buf, size_t len)
90 HttpServerSocket* sock = static_cast<HttpServerSocket*>(p->data);
91 return (sock->*f)(buf, len);
94 static void ConfigureParser()
96 http_parser_settings_init(&parser_settings);
97 parser_settings.on_message_begin = Callback<&HttpServerSocket::OnMessageBegin>;
98 parser_settings.on_url = DataCallback<&HttpServerSocket::OnUrl>;
99 parser_settings.on_header_field = DataCallback<&HttpServerSocket::OnHeaderField>;
100 parser_settings.on_body = DataCallback<&HttpServerSocket::OnBody>;
101 parser_settings.on_message_complete = Callback<&HttpServerSocket::OnMessageComplete>;
107 header_state = HEADER_NONE;
113 bool AcceptData(size_t len)
115 total_buffers += len;
116 return total_buffers < 8192;
119 int OnUrl(const char* buf, size_t len)
121 if (!AcceptData(len))
123 status_code = HTTP_STATUS_URI_TOO_LONG;
126 uri.append(buf, len);
130 enum { HEADER_NONE, HEADER_FIELD, HEADER_VALUE } header_state;
131 std::string header_field;
132 std::string header_value;
134 void OnHeaderComplete()
136 headers.SetHeader(header_field, header_value);
137 header_field.clear();
138 header_value.clear();
141 int OnHeaderField(const char* buf, size_t len)
143 if (header_state == HEADER_VALUE)
145 header_state = HEADER_FIELD;
146 if (!AcceptData(len))
148 status_code = HTTP_STATUS_REQUEST_HEADER_FIELDS_TOO_LARGE;
151 header_field.append(buf, len);
155 int OnHeaderValue(const char* buf, size_t len)
157 header_state = HEADER_VALUE;
158 if (!AcceptData(len))
160 status_code = HTTP_STATUS_REQUEST_HEADER_FIELDS_TOO_LARGE;
163 header_value.append(buf, len);
167 int OnHeadersComplete()
169 if (header_state != HEADER_NONE)
174 int OnBody(const char* buf, size_t len)
176 if (!AcceptData(len))
178 status_code = HTTP_STATUS_PAYLOAD_TOO_LARGE;
181 body.append(buf, len);
185 int OnMessageComplete()
192 HttpServerSocket(int newfd, const std::string& IP, ListenSocket* via, irc::sockets::sockaddrs* client, irc::sockets::sockaddrs* server, unsigned int timeoutsec)
193 : BufferedSocket(newfd)
199 if ((!via->iohookprovs.empty()) && (via->iohookprovs.back()))
201 via->iohookprovs.back()->OnAccept(this, client, server);
202 // IOHook may have errored
203 if (!getError().empty())
211 http_parser_init(&parser, HTTP_REQUEST);
212 ServerInstance->Timers.AddTimer(this);
220 void OnError(BufferedSocketError) CXX11_OVERRIDE
225 const char* Response(unsigned int response)
229 #define HTTP_STATUS_CASE(n, m, s) case n: return #s;
230 HTTP_STATUS_MAP(HTTP_STATUS_CASE)
237 void SendHTTPError(unsigned int response)
240 std::string data = InspIRCd::Format(
241 "<html><head></head><body>Server error %u: %s<br>"
242 "<small>Powered by <a href='http://www.inspircd.org'>InspIRCd</a></small></body></html>", response, Response(response));
244 SendHeaders(data.length(), response, empty);
249 void SendHeaders(unsigned long size, unsigned int response, HTTPHeaders &rheaders)
251 WriteData(InspIRCd::Format("HTTP/%u.%u %u %s\r\n", parser.http_major ? parser.http_major : 1, parser.http_major ? parser.http_minor : 1, response, Response(response)));
253 rheaders.CreateHeader("Date", InspIRCd::TimeString(ServerInstance->Time(), "%a, %d %b %Y %H:%M:%S GMT", true));
254 rheaders.CreateHeader("Server", INSPIRCD_BRANCH);
255 rheaders.SetHeader("Content-Length", ConvToStr(size));
258 rheaders.CreateHeader("Content-Type", "text/html");
260 rheaders.RemoveHeader("Content-Type");
262 /* Supporting Connection: keep-alive causes a whole world of hurt syncronizing timeouts,
263 * so remove it, its not essential for what we need.
265 rheaders.SetHeader("Connection", "Close");
267 WriteData(rheaders.GetFormattedHeaders());
271 void OnDataReady() CXX11_OVERRIDE
273 if (parser.upgrade || HTTP_PARSER_ERRNO(&parser))
275 http_parser_execute(&parser, &parser_settings, recvq.data(), recvq.size());
276 if (parser.upgrade || HTTP_PARSER_ERRNO(&parser))
277 SendHTTPError(status_code ? status_code : 400);
282 ModResult MOD_RESULT;
283 std::string method = http_method_str(static_cast<http_method>(parser.method));
284 HTTPRequestURI parsed;
285 ParseURI(uri, parsed);
286 HTTPRequest acl(method, parsed, &headers, this, ip, body);
287 FIRST_MOD_RESULT_CUSTOM(*aclevprov, HTTPACLEventListener, OnHTTPACLCheck, MOD_RESULT, (acl));
288 if (MOD_RESULT != MOD_RES_DENY)
290 HTTPRequest url(method, parsed, &headers, this, ip, body);
291 FIRST_MOD_RESULT_CUSTOM(*reqevprov, HTTPRequestEventListener, OnHTTPRequest, MOD_RESULT, (url));
292 if (MOD_RESULT == MOD_RES_PASSTHRU)
299 void Page(std::stringstream* n, unsigned int response, HTTPHeaders* hheaders)
301 SendHeaders(n->str().length(), response, *hheaders);
313 ServerInstance->GlobalCulls.AddItem(this);
316 bool ParseURI(const std::string& uri, HTTPRequestURI& out)
318 http_parser_url_init(&url);
319 if (http_parser_parse_url(uri.c_str(), uri.size(), 0, &url) != 0)
322 if (url.field_set & (1 << UF_PATH))
323 out.path = uri.substr(url.field_data[UF_PATH].off, url.field_data[UF_PATH].len);
325 if (url.field_set & (1 << UF_FRAGMENT))
326 out.fragment = uri.substr(url.field_data[UF_FRAGMENT].off, url.field_data[UF_FRAGMENT].len);
328 std::string param_str;
329 if (url.field_set & (1 << UF_QUERY))
330 param_str = uri.substr(url.field_data[UF_QUERY].off, url.field_data[UF_QUERY].len);
332 irc::sepstream param_stream(param_str, '&');
334 std::string::size_type eq_pos;
335 while (param_stream.GetToken(token))
337 eq_pos = token.find('=');
338 if (eq_pos == std::string::npos)
340 out.query_params.insert(std::make_pair(token, ""));
344 out.query_params.insert(std::make_pair(token.substr(0, eq_pos), token.substr(eq_pos + 1)));
351 class HTTPdAPIImpl : public HTTPdAPIBase
354 HTTPdAPIImpl(Module* parent)
355 : HTTPdAPIBase(parent)
359 void SendResponse(HTTPDocumentResponse& resp) CXX11_OVERRIDE
361 resp.src.sock->Page(resp.document, resp.responsecode, &resp.headers);
365 class ModuleHttpServer : public Module
367 HTTPdAPIImpl APIImpl;
368 unsigned int timeoutsec;
369 Events::ModuleEventProvider acleventprov;
370 Events::ModuleEventProvider reqeventprov;
375 , acleventprov(this, "event/http-acl")
376 , reqeventprov(this, "event/http-request")
378 aclevprov = &acleventprov;
379 reqevprov = &reqeventprov;
380 HttpServerSocket::ConfigureParser();
383 void init() CXX11_OVERRIDE
388 void ReadConfig(ConfigStatus& status) CXX11_OVERRIDE
390 ConfigTag* tag = ServerInstance->Config->ConfValue("httpd");
391 timeoutsec = tag->getDuration("timeout", 10, 1);
394 ModResult OnAcceptConnection(int nfd, ListenSocket* from, irc::sockets::sockaddrs* client, irc::sockets::sockaddrs* server) CXX11_OVERRIDE
396 if (!stdalgo::string::equalsci(from->bind_tag->getString("type"), "httpd"))
397 return MOD_RES_PASSTHRU;
399 sockets.push_front(new HttpServerSocket(nfd, client->addr(), from, client, server, timeoutsec));
400 return MOD_RES_ALLOW;
403 void OnUnloadModule(Module* mod) CXX11_OVERRIDE
405 for (insp::intrusive_list<HttpServerSocket>::const_iterator i = sockets.begin(); i != sockets.end(); )
407 HttpServerSocket* sock = *i;
409 if (sock->GetModHook(mod))
417 CullResult cull() CXX11_OVERRIDE
419 for (insp::intrusive_list<HttpServerSocket>::const_iterator i = sockets.begin(); i != sockets.end(); ++i)
421 HttpServerSocket* sock = *i;
424 return Module::cull();
427 Version GetVersion() CXX11_OVERRIDE
429 return Version("Provides HTTP serving facilities to modules", VF_VENDOR);
433 MODULE_INIT(ModuleHttpServer)