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 &param)
+	{
+
+		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;
+}