diff options
Diffstat (limited to 'src/modules')
| -rw-r--r-- | src/modules/m_xmlsocket.cpp | 194 |
1 files changed, 194 insertions, 0 deletions
diff --git a/src/modules/m_xmlsocket.cpp b/src/modules/m_xmlsocket.cpp new file mode 100644 index 000000000..8fcd72a52 --- /dev/null +++ b/src/modules/m_xmlsocket.cpp @@ -0,0 +1,194 @@ +/* +------------------------------------+ + * | Inspire Internet Relay Chat Daemon | + * +------------------------------------+ + * + * InspIRCd: (C) 2002-2007 InspIRCd Development Team + * See: http://www.inspircd.org/wiki/index.php/Credits + * + * This program is free but copyrighted software; see + * the file COPYING for details. + * + * --------------------------------------------------- + */ + +#include <string> +#include <vector> + +#include <openssl/ssl.h> +#include <openssl/err.h> + +#include "inspircd_config.h" +#include "configreader.h" +#include "users.h" +#include "channels.h" +#include "modules.h" + +#include "socket.h" +#include "hashcomp.h" +#include "inspircd.h" + +/* $ModDesc: Provides XMLSocket support for clients */ + + +class ModuleXMLSocket : public Module +{ + + ConfigReader* Conf; + + std::vector<int> listenports; + int clientactive; + + public: + + InspIRCd* PublicInstance; + + ModuleXMLSocket(InspIRCd* Me) + : Module::Module(Me), PublicInstance(Me) + { + OnRehash(NULL,""); + } + + virtual void OnRehash(userrec* user, const std::string ¶m) + { + + Conf = new ConfigReader(ServerInstance); + + for (unsigned int i = 0; i < listenports.size(); i++) + { + ServerInstance->Config->DelIOHook(listenports[i]); + } + + listenports.clear(); + clientactive = 0; + + for (int i = 0; i < Conf->Enumerate("bind"); i++) + { + // For each <bind> tag + if (((Conf->ReadValue("bind", "type", i) == "") || (Conf->ReadValue("bind", "type", i) == "clients")) && (Conf->ReadValue("bind", "xmlsocket", i) == "yes")) + { + // Get the port we're meant to be listening on with SSL + std::string port = Conf->ReadValue("bind", "port", i); + irc::portparser portrange(port, false); + long portno = -1; + while ((portno = portrange.GetToken())) + { + clientactive++; + try + { + if (ServerInstance->Config->AddIOHook(portno, this)) + { + listenports.push_back(portno); + for (unsigned int i = 0; i < ServerInstance->stats->BoundPortCount; i++) + if (ServerInstance->Config->ports[i] == portno) + ServerInstance->Config->openSockfd[i]->SetDescription("xml"); + } + else + { + ServerInstance->Log(DEFAULT, "m_xmlsocket.so: FAILED to enable XMLSocket on port %d, maybe you have another similar module loaded?", portno); + } + } + catch (ModuleException &e) + { + ServerInstance->Log(DEFAULT, "m_xmlsocket.so: FAILED to enable XMLSocket on port %d: %s. Maybe it's already hooked by the same port on a different IP, or you have another similar module loaded?", portno, e.GetReason()); + } + } + } + } + + DELETE(Conf); + } + + virtual ~ModuleXMLSocket() + { + } + + virtual void OnUnloadModule(Module* mod, const std::string &name) + { + if (mod == this) + { + for(unsigned int i = 0; i < listenports.size(); i++) + { + ServerInstance->Config->DelIOHook(listenports[i]); + for (unsigned int j = 0; j < ServerInstance->stats->BoundPortCount; j++) + if (ServerInstance->Config->ports[j] == listenports[i]) + if (ServerInstance->Config->openSockfd[j]) + ServerInstance->Config->openSockfd[j]->SetDescription("plaintext"); + } + } + } + + virtual Version GetVersion() + { + return Version(1, 1, 0, 0, VF_VENDOR, API_VERSION); + } + + void Implements(char* List) + { + List[I_OnUnloadModule] = List[I_OnRawSocketRead] = List[I_OnRawSocketWrite] = List[I_OnRehash] = 1; + } + + virtual int OnRawSocketRead(int fd, char* buffer, unsigned int count, int &readresult) + { + userrec* user = dynamic_cast<userrec*>(ServerInstance->FindDescriptor(fd)); + + if (user == NULL) + return -1; + + int result = user->ReadData(buffer, count); + + if ((result == -1) && (errno == EAGAIN)) + return -1; + else if (result < 1) + return 0; + + for (int n = 0; n < result; n++) + if (buffer[n] == 0) + buffer[n] = '\n'; + + readresult = result; + return result; + } + + virtual int OnRawSocketWrite(int fd, const char* buffer, int count) + { + userrec* user = dynamic_cast<userrec*>(ServerInstance->FindDescriptor(fd)); + + if (user == NULL) + return -1; + + char tmpbuffer[count+1]; + memcpy(&tmpbuffer, &buffer, count); + + for (int n = 0; n < count; n++) + if ((tmpbuffer[n] == '\r') || (tmpbuffer[n] == '\n')) + tmpbuffer[n] = 0; + + user->AddWriteBuf(std::string(tmpbuffer,count)); + + return 1; + } + +}; + +class ModuleXMLSocketFactory : public ModuleFactory +{ + public: + ModuleXMLSocketFactory() + { + } + + ~ModuleXMLSocketFactory() + { + } + + virtual Module * CreateModule(InspIRCd* Me) + { + return new ModuleXMLSocket(Me); + } +}; + + +extern "C" void * init_module( void ) +{ + return new ModuleXMLSocketFactory; +} |