summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorbrain <brain@e03df62e-2008-0410-955e-edbf42e46eb7>2006-07-11 19:20:18 +0000
committerbrain <brain@e03df62e-2008-0410-955e-edbf42e46eb7>2006-07-11 19:20:18 +0000
commitd67225f7e15127841f98a54748c73bff4da9f783 (patch)
treec48c0ef0113dd479ece361b5521ccfdb491769f1
parent14326e2186e95f491b2af3d04e1db9609838697a (diff)
Channel user count stuff
git-svn-id: http://svn.inspircd.org/repository/trunk/inspircd@4341 e03df62e-2008-0410-955e-edbf42e46eb7
-rw-r--r--src/modules/m_httpd_stats.cpp98
1 files changed, 97 insertions, 1 deletions
diff --git a/src/modules/m_httpd_stats.cpp b/src/modules/m_httpd_stats.cpp
index 7c43d19d8..93908a746 100644
--- a/src/modules/m_httpd_stats.cpp
+++ b/src/modules/m_httpd_stats.cpp
@@ -19,13 +19,27 @@ using namespace std;
#include <stdio.h>
#include "users.h"
#include "channels.h"
+#include "configreader.h"
#include "modules.h"
#include "inspsocket.h"
#include "helperfuncs.h"
#include "httpd.h"
+#include "inspircd.h"
/* $ModDesc: Provides statistics over HTTP via m_httpd.so */
+extern user_hash clientlist;
+extern chan_hash chanlist;
+extern std::vector<userrec*> all_opers;
+extern InspIRCd* ServerInstance;
+extern ServerConfig* Config;
+
+extern int MODCOUNT;
+
+typedef std::map<irc::string,int> StatsHash;
+typedef StatsHash::iterator StatsIter;
+static StatsHash* sh = new StatsHash();
+
class ModuleHttpStats : public Module
{
Server* Srv;
@@ -61,10 +75,44 @@ class ModuleHttpStats : public Module
data << "<TITLE>InspIRCd server statisitics for " << Srv->GetServerName() << " (" << Srv->GetServerDescription() << ")</TITLE>";
data << "</HEAD><BODY>";
data << "<H1>InspIRCd server statisitics for " << Srv->GetServerName() << " (" << Srv->GetServerDescription() << ")</H1>";
+
+ data << "<DIV ID='TOTALS'>";
+ data << "<H2>Totals</H2>";
+ data << "<TABLE>";
+ data << "<TR><TD>Users</TD><TD>" << clientlist.size() << "</TD></TR>";
+ data << "<TR><TD>Channels</TD><TD>" << chanlist.size() << "</TD></TR>";
+ data << "<TR><TD>Opers</TD><TD>" << all_opers.size() << "</TD></TR>";
+ data << "<TR><TD>Sockets</TD><TD>" << (ServerInstance->SE->GetMaxFds() - ServerInstance->SE->GetRemainingFds()) << " (Max: " << ServerInstance->SE->GetMaxFds() << " via socket engine '" << ServerInstance->SE->GetName() << "')</TD></TR>";
+ data << "</TABLE>";
+ data << "</DIV>";
+
+ data << "<DIV ID='MODULES'>";
+ data << "<H2>Modules</H2>";
+ data << "<TABLE>";
+ for (int i = 0; i <= MODCOUNT; i++)
+ {
+ if (Config->module_names[i] != "")
+ data << "<TR><TD>" << Config->module_names[i] << "</TD></TR>";
+ }
+ data << "</TABLE>";
+ data << "</DIV>";
+
+ data << "<DIV ID='CHANNELS'>";
+ data << "<H2>Channels</H2>";
+ data << "<TABLE>";
+ data << "<TR><TH>Users</TH><TH>Count</TH></TR>";
+ for (StatsIter a = sh->begin(); a != sh->end(); a++)
+ {
+ data << "<TR><TD>" << a->second << "</TD><TD>" << a->first << "</TD></TR>";
+ }
+ data << "</TABLE>";
+ data << "</DIV>";
+
data << "</BODY>";
data << "</HTML>";
+ /* Send the document back to m_httpd */
HTTPDocument response(http->sock, &data, 200, "X-Powered-By: m_http_stats.so\r\nContent-Type: text/html\r\n");
Request req((char*)&response, (Module*)this, event->GetSource());
req.Send();
@@ -74,6 +122,53 @@ class ModuleHttpStats : public Module
}
}
+ void OnChannelDelete(chanrec* chan)
+ {
+ StatsIter a = sh->find(chan->name);
+ if (a != sh->end())
+ {
+ sh->erase(a);
+ }
+ }
+
+ void OnUserJoin(userrec* user, chanrec* channel)
+ {
+ StatsIter a = sh->find(channel->name);
+ if (a != sh->end())
+ {
+ a->second++;
+ }
+ else
+ {
+ a[channel->name] = 1;
+ }
+ }
+
+ void OnUserPart(userrec* user, chanrec* channel, const std::string &partmessage)
+ {
+ StatsIter a = sh->find(channel->name);
+ if (a != sh->end())
+ {
+ a->second--;
+ }
+ }
+
+ void OnUserQuit(userrec* user, const std::string &message)
+ {
+ for (std::vector<ucrec*>::const_iterator v = user->chans.begin(); v != user->chans.end(); v++)
+ {
+ if (((ucrec*)(*v))->channel)
+ {
+ chanrec* c = ((ucrec*)(*v))->channel;
+ StatsIter a = sh->find(c->name);
+ if (a != sh->end())
+ {
+ a->second--;
+ }
+ }
+ }
+ }
+
char* OnRequest(Request* request)
{
return NULL;
@@ -81,11 +176,12 @@ class ModuleHttpStats : public Module
void Implements(char* List)
{
- List[I_OnEvent] = List[I_OnRequest] = 1;
+ List[I_OnEvent] = List[I_OnRequest] = List[I_OnChannelDelete] = List[I_OnUserJoin] = List[I_OnUserPart] = List[I_OnUserQuit] = 1;
}
virtual ~ModuleHttpStats()
{
+ delete sh;
}
virtual Version GetVersion()