]> git.netwichtig.de Git - user/henk/code/inspircd.git/blobdiff - src/modules/m_httpd_stats.cpp
Fix the DNS socket not being closed when core_dns is unloaded.
[user/henk/code/inspircd.git] / src / modules / m_httpd_stats.cpp
index 157f772c113fa453dce821e3e9f72e8afcd3fff7..f24fd9aec5ee8b326ea167538c91a153da360876 100644 (file)
-/*       +------------------------------------+
- *       | Inspire Internet Relay Chat Daemon |
- *       +------------------------------------+
+/*
+ * InspIRCd -- Internet Relay Chat Daemon
  *
- *  InspIRCd: (C) 2002-2008 InspIRCd Development Team
- * See: http://www.inspircd.org/wiki/index.php/Credits
+ *   Copyright (C) 2019 linuxdaemon <linuxdaemon.irc@gmail.com>
+ *   Copyright (C) 2018 Matt Schatz <genius3000@g3k.solutions>
+ *   Copyright (C) 2016 Johanna A <johanna-a@users.noreply.github.com>
+ *   Copyright (C) 2013-2016 Attila Molnar <attilamolnar@hush.com>
+ *   Copyright (C) 2013, 2017, 2019 Sadie Powell <sadie@witchery.services>
+ *   Copyright (C) 2012 Robby <robby@chatbelgie.be>
+ *   Copyright (C) 2009 Uli Schlachter <psychon@inspircd.org>
+ *   Copyright (C) 2009 Daniel De Graaf <danieldg@inspircd.org>
+ *   Copyright (C) 2008-2009 Robin Burchell <robin+git@viroteck.net>
+ *   Copyright (C) 2008 Pippijn van Steenhoven <pip88nl@gmail.com>
+ *   Copyright (C) 2007 John Brooks <special@inspircd.org>
+ *   Copyright (C) 2007 Dennis Friis <peavey@inspircd.org>
+ *   Copyright (C) 2006-2008, 2010 Craig Edwards <brain@inspircd.org>
  *
- * This program is free but copyrighted software; see
- *         the file COPYING for details.
+ * This file is part of InspIRCd.  InspIRCd 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, version 2.
  *
- * ---------------------------------------------------
+ * 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.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with this program.  If not, see <http://www.gnu.org/licenses/>.
  */
 
-#include "inspircd.h"
-#include "httpd.h"
 
-/* $ModDesc: Provides statistics over HTTP via m_httpd.so */
-/* $ModDep: httpd.h */
+#include "inspircd.h"
+#include "modules/httpd.h"
+#include "xline.h"
 
-typedef std::map<irc::string,int> StatsHash;
-typedef StatsHash::iterator StatsIter;
+namespace Stats
+{
+       struct Entities
+       {
+               static const insp::flat_map<char, char const*>& entities;
+       };
 
-typedef std::vector<std::pair<int,irc::string> > SortedList;
-typedef SortedList::iterator SortedIter;
+       static const insp::flat_map<char, char const*>& init_entities()
+       {
+               static insp::flat_map<char, char const*> entities;
+               entities['<'] = "lt";
+               entities['>'] = "gt";
+               entities['&'] = "amp";
+               entities['"'] = "quot";
+               return entities;
+       }
 
-static StatsHash* sh = new StatsHash();
-static SortedList* so = new SortedList();
+       const insp::flat_map<char, char const*>& Entities::entities = init_entities();
 
-static StatsHash* Servers = new StatsHash();
+       std::string Sanitize(const std::string& str)
+       {
+               std::string ret;
+               ret.reserve(str.length() * 2);
 
-class ModuleHttpStats : public Module
-{
-       
-       std::string stylesheet;
-       bool changed;
+               for (std::string::const_iterator x = str.begin(); x != str.end(); ++x)
+               {
+                       insp::flat_map<char, char const*>::const_iterator it = Entities::entities.find(*x);
 
- public:
+                       if (it != Entities::entities.end())
+                       {
+                               ret += '&';
+                               ret += it->second;
+                               ret += ';';
+                       }
+                       else if (*x == 0x09 || *x == 0x0A || *x == 0x0D || ((*x >= 0x20) && (*x <= 0x7e)))
+                       {
+                               // The XML specification defines the following characters as valid inside an XML document:
+                               // Char ::= #x9 | #xA | #xD | [#x20-#xD7FF] | [#xE000-#xFFFD] | [#x10000-#x10FFFF]
+                               ret += *x;
+                       }
+                       else
+                       {
+                               // If we reached this point then the string contains characters which can
+                               // not be represented in XML, even using a numeric escape. Therefore, we
+                               // Base64 encode the entire string and wrap it in a CDATA.
+                               ret.clear();
+                               ret += "<![CDATA[";
+                               ret += BinToBase64(str);
+                               ret += "]]>";
+                               break;
+                       }
+               }
+               return ret;
+       }
 
-       void ReadConfig()
+       void DumpMeta(std::ostream& data, Extensible* ext)
        {
-               ConfigReader c(ServerInstance);
-               this->stylesheet = c.ReadValue("httpstats", "stylesheet", 0);
+               data << "<metadata>";
+               for (Extensible::ExtensibleStore::const_iterator i = ext->GetExtList().begin(); i != ext->GetExtList().end(); i++)
+               {
+                       ExtensionItem* item = i->first;
+                       std::string value = item->ToHuman(ext, i->second);
+                       if (!value.empty())
+                               data << "<meta name=\"" << item->name << "\">" << Sanitize(value) << "</meta>";
+                       else if (!item->name.empty())
+                               data << "<meta name=\"" << item->name << "\"/>";
+               }
+               data << "</metadata>";
        }
 
-       ModuleHttpStats(InspIRCd* Me) : Module(Me)
+       std::ostream& ServerInfo(std::ostream& data)
        {
-               ReadConfig();
-               this->changed = true;
-               Implementation eventlist[] = { I_OnEvent, I_OnRequest, I_OnChannelDelete, I_OnUserJoin, I_OnUserPart, I_OnUserQuit };
-               ServerInstance->Modules->Attach(eventlist, this, 6);
+               return data << "<server><name>" << ServerInstance->Config->ServerName << "</name><description>"
+                       << Sanitize(ServerInstance->Config->ServerDesc) << "</description><version>"
+                       << Sanitize(ServerInstance->GetVersionString(true)) << "</version></server>";
        }
 
-       void InsertOrder(irc::string channel, int count)
+       std::ostream& ISupport(std::ostream& data)
        {
-               /* This function figures out where in the sorted list to put an item from the hash */
-               SortedIter a;
-               for (a = so->begin(); a != so->end(); a++)
+               data << "<isupport>";
+               const std::vector<Numeric::Numeric>& isupport = ServerInstance->ISupport.GetLines();
+               for (std::vector<Numeric::Numeric>::const_iterator i = isupport.begin(); i != isupport.end(); ++i)
                {
-                       /* Found an item equal to or less than, we insert our item before it */
-                       if (a->first <= count)
-                       {
-                               so->insert(a,std::pair<int,irc::string>(count,channel));
-                               return;
-                       }
+                       const Numeric::Numeric& num = *i;
+                       for (std::vector<std::string>::const_iterator j = num.GetParams().begin(); j != num.GetParams().end() - 1; ++j)
+                               data << "<token>" << Sanitize(*j) << "</token>";
                }
-               /* There are no items in the list yet, insert something at the beginning */
-               so->insert(so->begin(), std::pair<int,irc::string>(count,channel));
+               return data << "</isupport>";
        }
 
-       void SortList()
+       std::ostream& General(std::ostream& data)
        {
-               /* Sorts the hash into the sorted list using an insertion sort */
-               so->clear();
-               for (StatsIter a = sh->begin(); a != sh->end(); a++)
-                       InsertOrder(a->first, a->second);
-               for (user_hash::iterator u = ServerInstance->Users->clientlist->begin(); u != ServerInstance->Users->clientlist->end(); u++)
+               data << "<general>";
+               data << "<usercount>" << ServerInstance->Users->GetUsers().size() << "</usercount>";
+               data << "<localusercount>" << ServerInstance->Users->GetLocalUsers().size() << "</localusercount>";
+               data << "<channelcount>" << ServerInstance->GetChans().size() << "</channelcount>";
+               data << "<opercount>" << ServerInstance->Users->all_opers.size() << "</opercount>";
+               data << "<socketcount>" << (SocketEngine::GetUsedFds()) << "</socketcount><socketmax>" << SocketEngine::GetMaxFds() << "</socketmax>";
+               data << "<uptime><boot_time_t>" << ServerInstance->startup_time << "</boot_time_t></uptime>";
+               data << "<currenttime>" << ServerInstance->Time() << "</currenttime>";
+
+               data << ISupport;
+               return data << "</general>";
+       }
+
+       std::ostream& XLines(std::ostream& data)
+       {
+               data << "<xlines>";
+               std::vector<std::string> xltypes = ServerInstance->XLines->GetAllTypes();
+               for (std::vector<std::string>::iterator it = xltypes.begin(); it != xltypes.end(); ++it)
                {
-                       StatsHash::iterator n = Servers->find(u->second->server);
-                       if (n != Servers->end())
-                       {
-                               n->second++;
-                       }
-                       else
+                       XLineLookup* lookup = ServerInstance->XLines->GetAll(*it);
+
+                       if (!lookup)
+                               continue;
+                       for (LookupIter i = lookup->begin(); i != lookup->end(); ++i)
                        {
-                               Servers->insert(std::make_pair<irc::string,int>(u->second->server,1));
+                               data << "<xline type=\"" << it->c_str() << "\"><mask>"
+                                       << Sanitize(i->second->Displayable()) << "</mask><settime>"
+                                       << i->second->set_time << "</settime><duration>" << i->second->duration
+                                       << "</duration><reason>" << Sanitize(i->second->reason)
+                                       << "</reason></xline>";
                        }
                }
-               this->changed = false;
+               return data << "</xlines>";
        }
 
-       void OnEvent(Event* event)
+       std::ostream& Modules(std::ostream& data)
        {
-               std::stringstream data("");
+               data << "<modulelist>";
+               const ModuleManager::ModuleMap& mods = ServerInstance->Modules->GetModules();
 
-               if (event->GetEventID() == "httpd_url")
+               for (ModuleManager::ModuleMap::const_iterator i = mods.begin(); i != mods.end(); ++i)
                {
-                       HTTPRequest* http = (HTTPRequest*)event->GetData();
+                       Version v = i->second->GetVersion();
+                       data << "<module><name>" << i->first << "</name><description>" << Sanitize(v.description) << "</description></module>";
+               }
+               return data << "</modulelist>";
+       }
 
-                       if ((http->GetURI() == "/stats") || (http->GetURI() == "/stats/"))
+       std::ostream& Channels(std::ostream& data)
+       {
+               data << "<channellist>";
+
+               const chan_hash& chans = ServerInstance->GetChans();
+               for (chan_hash::const_iterator i = chans.begin(); i != chans.end(); ++i)
+               {
+                       Channel* c = i->second;
+
+                       data << "<channel>";
+                       data << "<usercount>" << c->GetUsers().size() << "</usercount><channelname>" << Sanitize(c->name) << "</channelname>";
+                       data << "<channeltopic>";
+                       data << "<topictext>" << Sanitize(c->topic) << "</topictext>";
+                       data << "<setby>" << Sanitize(c->setby) << "</setby>";
+                       data << "<settime>" << c->topicset << "</settime>";
+                       data << "</channeltopic>";
+                       data << "<channelmodes>" << Sanitize(c->ChanModes(true)) << "</channelmodes>";
+
+                       const Channel::MemberMap& ulist = c->GetUsers();
+                       for (Channel::MemberMap::const_iterator x = ulist.begin(); x != ulist.end(); ++x)
                        {
-                               data << "<inspircdstats>";
-
-                               data << "<server><name>" << ServerInstance->Config->ServerName << "</name><gecos>" << ServerInstance->Config->ServerDesc << "</gecos></server>";
-
-                               data << "<general>";
-                               data << "<usercount>" << ServerInstance->Users->clientlist->size() << "</usercount>";
-                               data << "<channelcount>" << ServerInstance->chanlist->size() << "</channelcount>";
-                               data << "<opercount>" << ServerInstance->Users->all_opers.size() << "</opercount>";
-                               data << "<socketcount>" << (ServerInstance->SE->GetMaxFds() - ServerInstance->SE->GetRemainingFds()) << "</socketcount><socketmax>" << ServerInstance->SE->GetMaxFds() <<
-                                       "</socketmax><socketengine>" << ServerInstance->SE->GetName() << "</socketengine>";
-
-                               time_t current_time = 0;
-                               current_time = ServerInstance->Time();
-                               time_t server_uptime = current_time - ServerInstance->startup_time;
-                               struct tm* stime;
-                               stime = gmtime(&server_uptime);
-                               data << "<uptime><days>" << stime->tm_yday << "</days><hours>" << stime->tm_hour << "</hours><mins>" << stime->tm_min << "</mins><secs>" << stime->tm_sec << "</secs></uptime>";
-
-
-                               data << "</general>";
-                               data << "<modulelist>";
-                               std::vector<std::string> module_names = ServerInstance->Modules->GetAllModuleNames(0);
-                               for (std::vector<std::string>::iterator i = module_names.begin(); i != module_names.end(); ++i)
-                               {
-                                       Module* m = ServerInstance->Modules->Find(i->c_str());
-                                       Version v = m->GetVersion();
-                                       data << "<module><name>" << *i << "</name><version>" << v.Major << "." <<  v.Minor << "." << v.Revision << "." << v.Build << "</version></module>";
-                               }
-                               data << "</modulelist>";
-
-                               data << "<channellist>";
-                               /* If the list has changed since last time it was displayed, re-sort it
-                                * this time only (not every time, as this would be moronic)
-                                */
-                               if (this->changed)
-                                       this->SortList();
-
-                               for (SortedIter a = so->begin(); a != so->end(); a++)
-                               {
-                                       Channel* c = ServerInstance->FindChan(a->second.c_str());
-                                       if (c && !c->IsModeSet('s') && !c->IsModeSet('p'))
-                                       {
-                                               data << "<channel>";
-                                               data << "<usercount>" << c->GetUsers()->size() << "</usercount><channelname>" << c->name << "</channelname>";
-                                               data << "<channelops>" << c->GetOppedUsers()->size() << "</channelops>";
-                                               data << "<channelhalfops>" << c->GetHalfoppedUsers()->size() << "</channelhalfops>";
-                                               data << "<channelvoices>" << c->GetVoicedUsers()->size() << "</channelvoices>";
-                                               data << "<channeltopic>" << c->topic << "</channeltopic>";
-                                               data << "<channelmodes>" << c->ChanModes(false) << "</channelmodes>";
-                                               data << "</channel>";
-                                       }
-                               }
-
-                               data << "</channellist>";
-
-                               data << "<serverlist>";
-                               
-                               for (StatsHash::iterator b = Servers->begin(); b != Servers->end(); b++)
-                               {
-                                       data << "<server>";
-                                       data << "<servername>" << b->first << "</servername>";
-                                       data << "<usercount>" << b->second << "</usercount>";
-                                       data << "</server>";
-                               }
-                               data << "</serverlist>";
-
-                               data << "</inspircdstats>";
-
-                               /* Send the document back to m_httpd */
-                               HTTPDocument response(http->sock, &data, 200);
-                               response.headers.SetHeader("X-Powered-By", "m_httpd_stats.so");
-                               response.headers.SetHeader("Content-Type", "text/xml");
-                               Request req((char*)&response, (Module*)this, event->GetSource());
-                               req.Send();
+                               Membership* memb = x->second;
+                               data << "<channelmember><uid>" << memb->user->uuid << "</uid><privs>"
+                                       << Sanitize(memb->GetAllPrefixChars()) << "</privs><modes>"
+                                       << memb->modes << "</modes>";
+                               DumpMeta(data, memb);
+                               data << "</channelmember>";
                        }
+
+                       DumpMeta(data, c);
+
+                       data << "</channel>";
                }
+
+               return data << "</channellist>";
        }
 
-       void OnChannelDelete(Channel* chan)
+       std::ostream& DumpUser(std::ostream& data, User* u)
        {
-               StatsIter a = sh->find(chan->name);
-               if (a != sh->end())
-               {
-                       sh->erase(a);
-               }
-               this->changed = true;
+               data << "<user>";
+               data << "<nickname>" << u->nick << "</nickname><uuid>" << u->uuid << "</uuid><realhost>"
+                       << u->GetRealHost() << "</realhost><displayhost>" << u->GetDisplayedHost() << "</displayhost><realname>"
+                       << Sanitize(u->GetRealName()) << "</realname><server>" << u->server->GetName() << "</server><signon>"
+                       << u->signon << "</signon><age>" << u->age << "</age>";
+
+               if (u->IsAway())
+                       data << "<away>" << Sanitize(u->awaymsg) << "</away><awaytime>" << u->awaytime << "</awaytime>";
+
+               if (u->IsOper())
+                       data << "<opertype>" << Sanitize(u->oper->name) << "</opertype>";
+
+               data << "<modes>" << u->GetModeLetters().substr(1) << "</modes><ident>" << Sanitize(u->ident) << "</ident>";
+
+               LocalUser* lu = IS_LOCAL(u);
+               if (lu)
+                       data << "<local/><port>" << lu->server_sa.port() << "</port><servaddr>"
+                               << lu->server_sa.str() << "</servaddr><connectclass>"
+                               << lu->GetClass()->GetName() << "</connectclass><lastmsg>"
+                               << lu->idle_lastmsg << "</lastmsg>";
+
+               data << "<ipaddress>" << u->GetIPString() << "</ipaddress>";
+
+               DumpMeta(data, u);
+
+               data << "</user>";
+               return data;
        }
 
-       void OnUserJoin(User* user, Channel* channel, bool sync, bool &silent)
+       std::ostream& Users(std::ostream& data)
        {
-               StatsIter a = sh->find(channel->name);
-               if (a != sh->end())
+               data << "<userlist>";
+               const user_hash& users = ServerInstance->Users->GetUsers();
+               for (user_hash::const_iterator i = users.begin(); i != users.end(); ++i)
                {
-                       a->second++;
+                       User* u = i->second;
+
+                       if (u->registered != REG_ALL)
+                               continue;
+
+                       DumpUser(data, u);
                }
-               else
+               return data << "</userlist>";
+       }
+
+       std::ostream& Servers(std::ostream& data)
+       {
+               data << "<serverlist>";
+
+               ProtocolInterface::ServerList sl;
+               ServerInstance->PI->GetServerList(sl);
+
+               for (ProtocolInterface::ServerList::const_iterator b = sl.begin(); b != sl.end(); ++b)
                {
-                       irc::string name = channel->name;
-                       sh->insert(std::pair<irc::string,int>(name,1));
+                       data << "<server>";
+                       data << "<servername>" << b->servername << "</servername>";
+                       data << "<parentname>" << b->parentname << "</parentname>";
+                       data << "<description>" << Sanitize(b->description) << "</description>";
+                       data << "<usercount>" << b->usercount << "</usercount>";
+// This is currently not implemented, so, commented out.
+//                                     data << "<opercount>" << b->opercount << "</opercount>";
+                       data << "<lagmillisecs>" << b->latencyms << "</lagmillisecs>";
+                       data << "</server>";
                }
-               this->changed = true;
+
+               return data << "</serverlist>";
        }
 
-       void OnUserPart(User* user, Channel* channel, const std::string &partmessage, bool &silent)
+       std::ostream& Commands(std::ostream& data)
        {
-               StatsIter a = sh->find(channel->name);
-               if (a != sh->end())
+               data << "<commandlist>";
+
+               const CommandParser::CommandMap& commands = ServerInstance->Parser.GetCommands();
+               for (CommandParser::CommandMap::const_iterator i = commands.begin(); i != commands.end(); ++i)
                {
-                       a->second--;
+                       data << "<command><name>" << i->second->name << "</name><usecount>" << i->second->use_count << "</usecount></command>";
                }
-               this->changed = true;
+               return data << "</commandlist>";
        }
 
-       void OnUserQuit(User* user, const std::string &message, const std::string &oper_message)
+       enum OrderBy
        {
-               for (UCListIter v = user->chans.begin(); v != user->chans.end(); v++)
+               OB_NICK,
+               OB_LASTMSG,
+
+               OB_NONE
+       };
+
+       struct UserSorter
+       {
+               OrderBy order;
+               bool desc;
+
+               UserSorter(OrderBy Order, bool Desc = false) : order(Order), desc(Desc) {}
+
+               template <typename T>
+               inline bool Compare(const T& a, const T& b)
                {
-                       Channel* c = v->first;
-                       StatsIter a = sh->find(c->name);
-                       if (a != sh->end())
-                       {
-                               a->second--;
+                       return desc ? a > b : a < b;
+               }
+
+               bool operator()(User* u1, User* u2)
+               {
+                       switch (order) {
+                               case OB_LASTMSG:
+                                       return Compare(IS_LOCAL(u1)->idle_lastmsg, IS_LOCAL(u2)->idle_lastmsg);
+                                       break;
+                               case OB_NICK:
+                                       return Compare(u1->nick, u2->nick);
+                                       break;
+                               default:
+                               case OB_NONE:
+                                       return false;
+                                       break;
                        }
                }
-               this->changed = true;
+       };
+
+       std::ostream& ListUsers(std::ostream& data, const HTTPQueryParameters& params)
+       {
+               if (params.empty())
+                       return Users(data);
+
+               data << "<userlist>";
+
+               // Filters
+               size_t limit = params.getNum<size_t>("limit");
+               bool showunreg = params.getBool("showunreg");
+               bool localonly = params.getBool("localonly");
+
+               // Minimum time since a user's last message
+               unsigned long min_idle = params.getDuration("minidle");
+               time_t maxlastmsg = ServerInstance->Time() - min_idle;
+
+               if (min_idle)
+                       // We can only check idle times on local users
+                       localonly = true;
+
+               // Sorting
+               const std::string& sortmethod = params.getString("sortby");
+               bool desc = params.getBool("desc", false);
+
+               OrderBy orderby;
+               if (stdalgo::string::equalsci(sortmethod, "nick"))
+                       orderby = OB_NICK;
+               else if (stdalgo::string::equalsci(sortmethod, "lastmsg"))
+               {
+                       orderby = OB_LASTMSG;
+                       // We can only check idle times on local users
+                       localonly = true;
+               }
+               else
+                       orderby = OB_NONE;
+
+               typedef std::list<User*> NewUserList;
+               NewUserList user_list;
+               user_hash users = ServerInstance->Users->GetUsers();
+               for (user_hash::iterator i = users.begin(); i != users.end(); ++i)
+               {
+                       User* u = i->second;
+                       if (!showunreg && u->registered != REG_ALL)
+                               continue;
+
+                       LocalUser* lu = IS_LOCAL(u);
+                       if (localonly && !lu)
+                               continue;
+
+                       if (min_idle && lu->idle_lastmsg > maxlastmsg)
+                               continue;
+
+                       user_list.push_back(u);
+               }
+
+               UserSorter sorter(orderby, desc);
+               if (sorter.order != OB_NONE && !(!localonly && sorter.order == OB_LASTMSG))
+                       user_list.sort(sorter);
+
+               size_t count = 0;
+               for (NewUserList::const_iterator i = user_list.begin(); i != user_list.end() && (!limit || count < limit); ++i, ++count)
+                       DumpUser(data, *i);
+
+               data << "</userlist>";
+               return data;
        }
+}
 
-       const char* OnRequest(Request* request)
+class ModuleHttpStats : public Module, public HTTPRequestEventListener
+{
+       HTTPdAPI API;
+       bool enableparams;
+
+ public:
+       ModuleHttpStats()
+               : HTTPRequestEventListener(this)
+               , API(this)
+               , enableparams(false)
+       {
+       }
+
+       void ReadConfig(ConfigStatus& status) CXX11_OVERRIDE
        {
-               return NULL;
+               ConfigTag* conf = ServerInstance->Config->ConfValue("httpstats");
+
+               // Parameterized queries may cause a performance issue
+               // Due to the sheer volume of data
+               // So default them to disabled
+               enableparams = conf->getBool("enableparams");
        }
 
+       ModResult HandleRequest(HTTPRequest* http)
+       {
+               if (http->GetPath() != "/stats")
+                       return MOD_RES_PASSTHRU;
+
+               ServerInstance->Logs->Log(MODNAME, LOG_DEBUG, "Handling HTTP request for %s", http->GetPath().c_str());
+
+               bool found = true;
+               std::stringstream data;
+               data << "<inspircdstats>";
+
+               if (http->GetPath() == "/stats")
+               {
+                       data << Stats::ServerInfo << Stats::General
+                               << Stats::XLines << Stats::Modules
+                               << Stats::Channels << Stats::Users
+                               << Stats::Servers << Stats::Commands;
+               }
+               else if (http->GetPath() == "/stats/general")
+               {
+                       data << Stats::General;
+               }
+               else if (http->GetPath() == "/stats/users")
+               {
+                       if (enableparams)
+                               Stats::ListUsers(data, http->GetParsedURI().query_params);
+                       else
+                               data << Stats::Users;
+               }
+               else
+               {
+                       found = false;
+               }
+
+               if (found)
+               {
+                       data << "</inspircdstats>";
+               }
+               else
+               {
+                       data.clear();
+                       data.str(std::string());
+               }
+
+               /* Send the document back to m_httpd */
+               HTTPDocumentResponse response(this, *http, &data, found ? 200 : 404);
+               response.headers.SetHeader("X-Powered-By", MODNAME);
+               response.headers.SetHeader("Content-Type", "text/xml");
+               API->SendResponse(response);
+               return MOD_RES_DENY; // Handled
+       }
 
-       virtual ~ModuleHttpStats()
+       ModResult OnHTTPRequest(HTTPRequest& req) CXX11_OVERRIDE
        {
-               delete sh;
-               delete so;
+               return HandleRequest(&req);
        }
 
-       virtual Version GetVersion()
+       Version GetVersion() CXX11_OVERRIDE
        {
-               return Version(1, 2, 0, 0, VF_VENDOR, API_VERSION);
+               return Version("Provides XML-serialised statistics about the server, channels, and users over HTTP via the /stats path.", VF_VENDOR);
        }
 };