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/>.
28 /* $ModDesc: Provides HTTP serving facilities to modules */
29 /* $ModDep: httpd.h */
31 class ModuleHttpServer;
33 static ModuleHttpServer* HttpModule;
35 static std::set<HttpServerSocket*> sockets;
37 /** HTTP socket states
41 HTTP_SERVE_WAIT_REQUEST = 0, /* Waiting for a full request */
42 HTTP_SERVE_RECV_POSTDATA = 1, /* Waiting to finish recieving POST data */
43 HTTP_SERVE_SEND_DATA = 2 /* Sending response */
46 /** A socket used for HTTP transport
48 class HttpServerSocket : public BufferedSocket
50 HttpState InternalState;
54 std::string reqbuffer;
56 unsigned int postsize;
57 std::string request_type;
59 std::string http_version;
62 const time_t createtime;
64 HttpServerSocket(int newfd, const std::string& IP, ListenSocket* via, irc::sockets::sockaddrs* client, irc::sockets::sockaddrs* server)
65 : BufferedSocket(newfd), ip(IP), postsize(0)
66 , createtime(ServerInstance->Time())
68 InternalState = HTTP_SERVE_WAIT_REQUEST;
70 FOREACH_MOD(I_OnHookIO, OnHookIO(this, via));
72 GetIOHook()->OnStreamSocketAccept(this, client, server);
80 virtual void OnError(BufferedSocketError)
82 ServerInstance->GlobalCulls.AddItem(this);
85 std::string Response(int response)
92 return "SWITCHING PROTOCOLS";
100 return "NON-AUTHORITATIVE INFORMATION";
104 return "RESET CONTENT";
106 return "PARTIAL CONTENT";
108 return "MULTIPLE CHOICES";
110 return "MOVED PERMANENTLY";
116 return "NOT MODIFIED";
120 return "TEMPORARY REDIRECT";
122 return "BAD REQUEST";
124 return "UNAUTHORIZED";
126 return "PAYMENT REQUIRED";
132 return "METHOD NOT ALLOWED";
134 return "NOT ACCEPTABLE";
136 return "PROXY AUTHENTICATION REQUIRED";
138 return "REQUEST TIMEOUT";
144 return "LENGTH REQUIRED";
146 return "PRECONDITION FAILED";
148 return "REQUEST ENTITY TOO LARGE";
150 return "REQUEST-URI TOO LONG";
152 return "UNSUPPORTED MEDIA TYPE";
154 return "REQUESTED RANGE NOT SATISFIABLE";
156 return "EXPECTATION FAILED";
158 return "INTERNAL SERVER ERROR";
160 return "NOT IMPLEMENTED";
162 return "BAD GATEWAY";
164 return "SERVICE UNAVAILABLE";
166 return "GATEWAY TIMEOUT";
168 return "HTTP VERSION NOT SUPPORTED";
176 void SendHTTPError(int response)
179 std::string data = "<html><head></head><body>Server error "+ConvToStr(response)+": "+Response(response)+"<br>"+
180 "<small>Powered by <a href='http://www.inspircd.org'>InspIRCd</a></small></body></html>";
182 SendHeaders(data.length(), response, empty);
186 void SendHeaders(unsigned long size, int response, HTTPHeaders &rheaders)
189 WriteData(http_version + " "+ConvToStr(response)+" "+Response(response)+"\r\n");
191 time_t local = ServerInstance->Time();
192 struct tm *timeinfo = gmtime(&local);
193 char *date = asctime(timeinfo);
194 date[strlen(date) - 1] = '\0';
195 rheaders.CreateHeader("Date", date);
197 rheaders.CreateHeader("Server", BRANCH);
198 rheaders.SetHeader("Content-Length", ConvToStr(size));
201 rheaders.CreateHeader("Content-Type", "text/html");
203 rheaders.RemoveHeader("Content-Type");
205 /* Supporting Connection: keep-alive causes a whole world of hurt syncronizing timeouts,
206 * so remove it, its not essential for what we need.
208 rheaders.SetHeader("Connection", "Close");
210 WriteData(rheaders.GetFormattedHeaders());
216 if (InternalState == HTTP_SERVE_RECV_POSTDATA)
218 postdata.append(recvq);
219 if (postdata.length() >= postsize)
224 reqbuffer.append(recvq);
226 if (reqbuffer.length() >= 8192)
228 ServerInstance->Logs->Log("m_httpd",DEBUG, "m_httpd dropped connection due to an oversized request buffer");
233 if (InternalState == HTTP_SERVE_WAIT_REQUEST)
234 CheckRequestBuffer();
238 void CheckRequestBuffer()
240 std::string::size_type reqend = reqbuffer.find("\r\n\r\n");
241 if (reqend == std::string::npos)
244 // We have the headers; parse them all
245 std::string::size_type hbegin = 0, hend;
246 while ((hend = reqbuffer.find("\r\n", hbegin)) != std::string::npos)
251 if (request_type.empty())
253 std::istringstream cheader(std::string(reqbuffer, hbegin, hend - hbegin));
254 cheader >> request_type;
256 cheader >> http_version;
258 if (request_type.empty() || uri.empty() || http_version.empty())
268 std::string cheader = reqbuffer.substr(hbegin, hend - hbegin);
270 std::string::size_type fieldsep = cheader.find(':');
271 if ((fieldsep == std::string::npos) || (fieldsep == 0) || (fieldsep == cheader.length() - 1))
277 headers.SetHeader(cheader.substr(0, fieldsep), cheader.substr(fieldsep + 2));
282 reqbuffer.erase(0, reqend + 4);
284 std::transform(request_type.begin(), request_type.end(), request_type.begin(), ::toupper);
285 std::transform(http_version.begin(), http_version.end(), http_version.begin(), ::toupper);
287 if ((http_version != "HTTP/1.1") && (http_version != "HTTP/1.0"))
293 if (headers.IsSet("Content-Length") && (postsize = ConvToInt(headers.GetHeader("Content-Length"))) > 0)
295 InternalState = HTTP_SERVE_RECV_POSTDATA;
297 if (reqbuffer.length() >= postsize)
299 postdata = reqbuffer.substr(0, postsize);
300 reqbuffer.erase(0, postsize);
302 else if (!reqbuffer.empty())
304 postdata = reqbuffer;
308 if (postdata.length() >= postsize)
319 InternalState = HTTP_SERVE_SEND_DATA;
322 HTTPRequest acl((Module*)HttpModule, "httpd_acl", request_type, uri, &headers, this, ip, postdata);
326 HTTPRequest url((Module*)HttpModule, "httpd_url", request_type, uri, &headers, this, ip, postdata);
335 void Page(std::stringstream* n, int response, HTTPHeaders *hheaders)
337 SendHeaders(n->str().length(), response, *hheaders);
342 class ModuleHttpServer : public Module
344 unsigned int timeoutsec;
351 Implementation eventlist[] = { I_OnAcceptConnection, I_OnBackgroundTimer, I_OnRehash, I_OnUnloadModule };
352 ServerInstance->Modules->Attach(eventlist, this, sizeof(eventlist)/sizeof(Implementation));
356 void OnRehash(User* user)
358 ConfigTag* tag = ServerInstance->Config->ConfValue("httpd");
359 timeoutsec = tag->getInt("timeout");
362 void OnRequest(Request& request)
364 if (strcmp(request.id, "HTTP-DOC") != 0)
366 HTTPDocumentResponse& resp = static_cast<HTTPDocumentResponse&>(request);
368 resp.src.sock->Page(resp.document, resp.responsecode, &resp.headers);
371 ModResult OnAcceptConnection(int nfd, ListenSocket* from, irc::sockets::sockaddrs* client, irc::sockets::sockaddrs* server)
373 if (from->bind_tag->getString("type") != "httpd")
374 return MOD_RES_PASSTHRU;
376 std::string incomingip;
377 irc::sockets::satoap(*client, incomingip, port);
378 sockets.insert(new HttpServerSocket(nfd, incomingip, from, client, server));
379 return MOD_RES_ALLOW;
382 void OnBackgroundTimer(time_t curtime)
387 time_t oldest_allowed = curtime - timeoutsec;
388 for (std::set<HttpServerSocket*>::const_iterator i = sockets.begin(); i != sockets.end(); )
390 HttpServerSocket* sock = *i;
392 if (sock->createtime < oldest_allowed)
400 void OnUnloadModule(Module* mod)
402 for (std::set<HttpServerSocket*>::const_iterator i = sockets.begin(); i != sockets.end(); )
404 HttpServerSocket* sock = *i;
406 if (sock->GetIOHook() == mod)
416 std::set<HttpServerSocket*> local;
418 for (std::set<HttpServerSocket*>::const_iterator i = local.begin(); i != local.end(); ++i)
420 HttpServerSocket* sock = *i;
424 return Module::cull();
427 virtual Version GetVersion()
429 return Version("Provides HTTP serving facilities to modules", VF_VENDOR);
433 MODULE_INIT(ModuleHttpServer)