]> git.netwichtig.de Git - user/henk/code/inspircd.git/blobdiff - src/modules/extra/m_sqloper.cpp
Try this as the ssl crash fix
[user/henk/code/inspircd.git] / src / modules / extra / m_sqloper.cpp
index 09b577aedd2d3b7d01c3f3f8da18c5a4e29a22f9..c7c2e0c0dc79bc55a50a0a272d914fff1a114a13 100644 (file)
@@ -2,7 +2,7 @@
  *       | Inspire Internet Relay Chat Daemon |
  *       +------------------------------------+
  *
- *  InspIRCd: (C) 2002-2008 InspIRCd Development Team
+ *  InspIRCd: (C) 2002-2009 InspIRCd Development Team
  * See: http://www.inspircd.org/wiki/index.php/Credits
  *
  * This program is free but copyrighted software; see
  */
 
 #include "inspircd.h"
-#include "users.h"
-#include "channels.h"
-#include "modules.h"
-#include "configreader.h"
-
 #include "m_sqlv2.h"
 #include "m_sqlutils.h"
 #include "m_hash.h"
@@ -38,7 +33,7 @@ class ModuleSQLOper : public Module
 
 public:
        ModuleSQLOper(InspIRCd* Me)
-       : Module::Module(Me)
+       : Module(Me)
        {
                ServerInstance->Modules->UseInterface("SQLutils");
                ServerInstance->Modules->UseInterface("SQL");
@@ -78,6 +73,21 @@ public:
                ServerInstance->Modules->Attach(eventlist, this, 3);
        }
 
+       
+       bool OneOfMatches(const char* host, const char* ip, const char* hostlist)
+       {
+               std::stringstream hl(hostlist);
+               std::string xhost;
+               while (hl >> xhost)
+               {
+                       if (InspIRCd::Match(host, xhost, ascii_case_insensitive_map) || InspIRCd::MatchCIDR(ip, xhost, ascii_case_insensitive_map))
+                       {
+                               return true;
+                       }
+               }
+               return false;
+       }
+
        virtual void OnLoadModule(Module* mod, const std::string& name)
        {
                if (ServerInstance->Modules->ModuleHasInterface(mod, "HashRequest"))
@@ -106,17 +116,17 @@ public:
        virtual void OnRehash(User* user, const std::string &parameter)
        {
                ConfigReader Conf(ServerInstance);
-               
+
                databaseid = Conf.ReadValue("sqloper", "dbid", 0); /* Database ID of a database configured for the service provider module */
                hashtype = assign(Conf.ReadValue("sqloper", "hash", 0));
        }
 
-       virtual int OnPreCommand(const std::string &command, const std::vector<std::string> &parameters, User *user, bool validated, const std::string &original_line)
+       virtual int OnPreCommand(std::string &command, std::vector<std::string> &parameters, User *user, bool validated, const std::string &original_line)
        {
                if ((validated) && (command == "OPER"))
                {
                        if (LookupOper(user, parameters[0], parameters[1]))
-                       {       
+                       {
                                /* Returning true here just means the query is in progress, or on it's way to being
                                 * in progress. Nothing about the /oper actually being successful..
                                 * If the oper lookup fails later, we pass the command to the original handler
@@ -131,7 +141,7 @@ public:
        bool LookupOper(User* user, const std::string &username, const std::string &password)
        {
                Module* target;
-               
+
                target = ServerInstance->Modules->FindFeature("SQL");
 
                if (target)
@@ -150,7 +160,7 @@ public:
                         */
                        SQLrequest req = SQLrequest(this, target, databaseid,
                                        SQLquery("SELECT username, password, hostname, type FROM ircd_opers WHERE username = '?' AND password='?'") % username % md5_pass_hash);
-                       
+
                        if (req.Send())
                        {
                                /* When we get the query response from the service provider we will be given an ID to play with,
@@ -164,7 +174,7 @@ public:
 
                                user->Extend("oper_user", strdup(username.c_str()));
                                user->Extend("oper_pass", strdup(password.c_str()));
-                                       
+
                                return true;
                        }
                        else
@@ -178,7 +188,7 @@ public:
                        return false;
                }
        }
-       
+
        virtual const char* OnRequest(Request* request)
        {
                if (strcmp(SQLRESID, request->GetId()) == 0)
@@ -193,29 +203,29 @@ public:
 
                        user->GetExt("oper_user", tried_user);
                        user->GetExt("oper_pass", tried_pass);
-                       
+
                        if (user)
                        {
-                               if (res->error.Id() == NO_ERROR)
+                               if (res->error.Id() == SQL_NO_ERROR)
                                {
                                        if (res->Rows())
                                        {
                                                /* We got a row in the result, this means there was a record for the oper..
                                                 * now we just need to check if their host matches, and if it does then
                                                 * oper them up.
-                                                * 
+                                                *
                                                 * We now (previous versions of the module didn't) support multiple SQL
                                                 * rows per-oper in the same way the config file does, all rows will be tried
                                                 * until one is found which matches. This is useful to define several different
                                                 * hosts for a single oper.
-                                                * 
+                                                *
                                                 * The for() loop works as SQLresult::GetRowMap() returns an empty map when there
                                                 * are no more rows to return.
                                                 */
-                                               
+
                                                for (SQLfieldMap& row = res->GetRowMap(); row.size(); row = res->GetRowMap())
-                                               {                                                       
-                                                       if (OperUser(user, row["username"].d, row["password"].d, row["hostname"].d, row["type"].d))
+                                               {
+                                                       if (OperUser(user, row["hostname"].d, row["type"].d))
                                                        {
                                                                /* If/when one of the rows matches, stop checking and return */
                                                                return SQLSUCCESS;
@@ -263,7 +273,7 @@ public:
 
                                }
                        }
-               
+
                        return SQLSUCCESS;
                }
 
@@ -277,8 +287,8 @@ public:
                if (oper_command)
                {
                        std::vector<std::string> params;
-                       params[0] = username;
-                       params[1] = pass;
+                       params.push_back(username);
+                       params.push_back(pass);
                        oper_command->Handle(params, user);
                }
                else
@@ -287,17 +297,17 @@ public:
                }
        }
 
-       bool OperUser(User* user, const std::string &username, const std::string &password, const std::string &pattern, const std::string &type)
+       bool OperUser(User* user, const std::string &pattern, const std::string &type)
        {
                ConfigReader Conf(ServerInstance);
-               
+
                for (int j = 0; j < Conf.Enumerate("type"); j++)
                {
                        std::string tname = Conf.ReadValue("type","name",j);
                        std::string hostname(user->ident);
 
                        hostname.append("@").append(user->host);
-                                                       
+
                        if ((tname == type) && OneOfMatches(hostname.c_str(), user->GetIPString(), pattern.c_str()))
                        {
                                /* Opertype and host match, looks like this is it. */
@@ -306,24 +316,19 @@ public:
                                if (operhost.size())
                                        user->ChangeDisplayedHost(operhost.c_str());
 
-                               ServerInstance->SNO->WriteToSnoMask('o',"%s (%s@%s) is now an IRC operator of type %s", user->nick, user->ident, user->host, type.c_str());
-                               user->WriteNumeric(381, "%s :You are now %s %s",user->nick, strchr("aeiouAEIOU", type[0]) ? "an" : "a", irc::Spacify(type.c_str()));
-
-                               if (!user->modes[UM_OPERATOR])
-                                       user->Oper(type, tname);
-
+                               user->Oper(type, tname);
                                return true;
                        }
                }
-               
+
                return false;
        }
 
        virtual Version GetVersion()
        {
-               return Version(1,2,1,0,VF_VENDOR,API_VERSION);
+               return Version("$Id$", VF_VENDOR, API_VERSION);
        }
-       
+
 };
 
 MODULE_INIT(ModuleSQLOper)