]> git.netwichtig.de Git - user/henk/code/inspircd.git/blobdiff - src/modules/m_banredirect.cpp
Introduce ModeProcessFlags, can be passed to ModeParser::Process() to indicate local...
[user/henk/code/inspircd.git] / src / modules / m_banredirect.cpp
index a8add0c72e78d5f01e4bccd47a79c836d5431ad2..a88324fe2cc9dac19548248e7e25038c1ff63feb 100644 (file)
@@ -1,25 +1,36 @@
-/*       +------------------------------------+
- *       | 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) 2009 Daniel De Graaf <danieldg@inspircd.org>
+ *   Copyright (C) 2007, 2009 Robin Burchell <robin+git@viroteck.net>
+ *   Copyright (C) 2008 Pippijn van Steenhoven <pip88nl@gmail.com>
+ *   Copyright (C) 2007 Dennis Friis <peavey@inspircd.org>
+ *   Copyright (C) 2007 Craig Edwards <craigedwards@brainbox.cc>
+ *   Copyright (C) 2007 Oliver Lupton <oliverlupton@gmail.com>
  *
- * 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 "u_listmode.h"
+#include "listmode.h"
 
 /* $ModDesc: Allows an extended ban (+b) syntax redirecting banned users to another channel */
 
-/* Originally written by Om, January 2008
+/* Originally written by Om, January 2009
  */
 
-class BanRedirectEntry : public classbase
+class BanRedirectEntry
 {
  public:
        std::string targetchan;
@@ -32,19 +43,20 @@ class BanRedirectEntry : public classbase
 };
 
 typedef std::vector<BanRedirectEntry> BanRedirectList;
-typedef std::deque<std::string> StringDeque;
 
 class BanRedirect : public ModeWatcher
 {
- private:
-       InspIRCd* Srv;
+       ModeReference ban;
  public:
-       BanRedirect(InspIRCd* Instance)
-       : ModeWatcher(Instance, 'b', MODETYPE_CHANNEL), Srv(Instance)
+       SimpleExtItem<BanRedirectList> extItem;
+       BanRedirect(Module* parent)
+               : ModeWatcher(parent, "ban", MODETYPE_CHANNEL)
+               , ban(parent, "ban")
+               , extItem("banredirect", parent)
        {
        }
 
-       bool BeforeMode(User* source, User* dest, Channel* channel, std::string &param, bool adding, ModeType type, bool)
+       bool BeforeMode(User* source, User* dest, Channel* channel, std::string &param, bool adding)
        {
                /* nick!ident@host -> nick!ident@host
                 * nick!ident@host#chan -> nick!ident@host#chan
@@ -52,22 +64,27 @@ class BanRedirect : public ModeWatcher
                 * nick!ident#chan -> nick!ident@*#chan
                 * nick#chan -> nick!*@*#chan
                 */
-               
-               if(channel && (type == MODETYPE_CHANNEL) && param.length())
+
+               if ((channel) && !param.empty())
                {
                        BanRedirectList* redirects;
-                       
+
                        std::string mask[4];
                        enum { NICK, IDENT, HOST, CHAN } current = NICK;
                        std::string::iterator start_pos = param.begin();
-                       long maxbans = channel->GetMaxBans();
-               
-                       if(adding && (channel->bans.size() > static_cast<unsigned>(maxbans)))
+
+                       if (param.length() >= 2 && param[1] == ':')
+                               return true;
+
+                       ListModeBase* banlm = static_cast<ListModeBase*>(*ban);
+                       unsigned int maxbans = banlm->GetLimit(channel);
+                       ListModeBase::ModeList* list = banlm->GetList(channel);
+                       if ((list) && (adding) && (maxbans <= list->size()))
                        {
-                               source->WriteNumeric(478, "%s %s :Channel ban list for %s is full (maximum entries for this channel is %ld)", source->nick.c_str(), channel->name.c_str(), channel->name.c_str(), maxbans);
+                               source->WriteNumeric(478, "%s %s :Channel ban list for %s is full (maximum entries for this channel is %u)", source->nick.c_str(), channel->name.c_str(), channel->name.c_str(), maxbans);
                                return false;
                        }
-                       
+
                        for(std::string::iterator curr = start_pos; curr != param.end(); curr++)
                        {
                                switch(*curr)
@@ -83,25 +100,29 @@ class BanRedirect : public ModeWatcher
                                                start_pos = curr+1;
                                                break;
                                        case '#':
-                                               mask[current].assign(start_pos, curr);
-                                               current = CHAN;
-                                               start_pos = curr;
+                                               /* bug #921: don't barf when redirecting to ## channels */
+                                               if (current != CHAN)
+                                               {
+                                                       mask[current].assign(start_pos, curr);
+                                                       current = CHAN;
+                                                       start_pos = curr;
+                                               }
                                                break;
                                }
                        }
-                               
+
                        if(mask[current].empty())
                        {
-                               mask[current].assign(start_pos, param.end());   
+                               mask[current].assign(start_pos, param.end());
                        }
-                       
+
                        /* nick@host wants to be changed to *!nick@host rather than nick!*@host... */
                        if(mask[NICK].length() && mask[HOST].length() && mask[IDENT].empty())
                        {
                                /* std::string::swap() is fast - it runs in constant time */
                                mask[NICK].swap(mask[IDENT]);
                        }
-                               
+
                        for(int i = 0; i < 3; i++)
                        {
                                if(mask[i].empty())
@@ -109,229 +130,220 @@ class BanRedirect : public ModeWatcher
                                        mask[i].assign("*");
                                }
                        }
-                               
+
                        param.assign(mask[NICK]).append(1, '!').append(mask[IDENT]).append(1, '@').append(mask[HOST]);
-       
+
                        if(mask[CHAN].length())
                        {
-                               if(Srv->IsChannel(mask[CHAN].c_str()))
+                               if (adding && IS_LOCAL(source))
                                {
+                                       if (!ServerInstance->IsChannel(mask[CHAN]))
+                                       {
+                                               source->WriteNumeric(403, "%s %s :Invalid channel name in redirection (%s)", source->nick.c_str(), channel->name.c_str(), mask[CHAN].c_str());
+                                               return false;
+                                       }
+
+                                       Channel *c = ServerInstance->FindChan(mask[CHAN]);
+                                       if (!c)
+                                       {
+                                               source->WriteNumeric(690, "%s :Target channel %s must exist to be set as a redirect.",source->nick.c_str(),mask[CHAN].c_str());
+                                               return false;
+                                       }
+                                       else if (adding && c->GetPrefixValue(source) < OP_VALUE)
+                                       {
+                                               source->WriteNumeric(690, "%s :You must be opped on %s to set it as a redirect.",source->nick.c_str(), mask[CHAN].c_str());
+                                               return false;
+                                       }
+
                                        if (assign(channel->name) == mask[CHAN])
                                        {
                                                source->WriteNumeric(690, "%s %s :You cannot set a ban redirection to the channel the ban is on", source->nick.c_str(), channel->name.c_str());
                                                return false;
                                        }
-                                       else
+                               }
+
+                               if(adding)
+                               {
+                                       /* It's a properly valid redirecting ban, and we're adding it */
+                                       redirects = extItem.get(channel);
+                                       if (!redirects)
                                        {
-                                               if(adding)
-                                               {
-                                                       /* It's a properly valid redirecting ban, and we're adding it */
-                                                       if(!channel->GetExt("banredirects", redirects))
-                                                       {
-                                                               redirects = new BanRedirectList;
-                                                               channel->Extend("banredirects", redirects);
-                                                       }
-                               
-                                                       /* Here 'param' doesn't have the channel on it yet */
-                                                       redirects->push_back(BanRedirectEntry(mask[CHAN].c_str(), param.c_str()));
-                                                       
-                                                       /* Now it does */
-                                                       param.append(mask[CHAN]);
-                                               }
-                                               else
+                                               redirects = new BanRedirectList;
+                                               extItem.set(channel, redirects);
+                                       }
+
+                                       /* Here 'param' doesn't have the channel on it yet */
+                                       redirects->push_back(BanRedirectEntry(mask[CHAN], param));
+
+                                       /* Now it does */
+                                       param.append(mask[CHAN]);
+                               }
+                               else
+                               {
+                                       /* Removing a ban, if there's no extensible there are no redirecting bans and we're fine. */
+                                       redirects = extItem.get(channel);
+                                       if (redirects)
+                                       {
+                                               /* But there were, so we need to remove the matching one if there is one */
+
+                                               for(BanRedirectList::iterator redir = redirects->begin(); redir != redirects->end(); redir++)
                                                {
-                                                       /* Removing a ban, if there's no extensible there are no redirecting bans and we're fine. */
-                                                       if(channel->GetExt("banredirects", redirects))
+                                                       /* Ugly as fuck */
+                                                       if((irc::string(redir->targetchan.c_str()) == irc::string(mask[CHAN].c_str())) && (irc::string(redir->banmask.c_str()) == irc::string(param.c_str())))
                                                        {
-                                                               /* But there were, so we need to remove the matching one if there is one */
-                                       
-                                                               for(BanRedirectList::iterator redir = redirects->begin(); redir != redirects->end(); redir++)
+                                                               redirects->erase(redir);
+
+                                                               if(redirects->empty())
                                                                {
-                                                                       /* Ugly as fuck */
-                                                                       if((irc::string(redir->targetchan.c_str()) == irc::string(mask[CHAN].c_str())) && (irc::string(redir->banmask.c_str()) == irc::string(param.c_str())))
-                                                                       {
-                                                                               redirects->erase(redir);
-                                                                               
-                                                                               if(redirects->empty())
-                                                                               {
-                                                                                       delete redirects;
-                                                                                       channel->Shrink("banredirects");
-                                                                               }
-                                                                               
-                                                                               break;
-                                                                       }
+                                                                       extItem.unset(channel);
                                                                }
+
+                                                               break;
                                                        }
-                                                       
-                                                       /* Append the channel so the default +b handler can remove the entry too */
-                                                       param.append(mask[CHAN]);
                                                }
                                        }
-                               }
-                               else
-                               {
-                                       source->WriteNumeric(403, "%s %s :Invalid channel name in redirection (%s)", source->nick.c_str(), channel->name.c_str(), mask[CHAN].c_str());
-                                       return false;
+
+                                       /* Append the channel so the default +b handler can remove the entry too */
+                                       param.append(mask[CHAN]);
                                }
                        }
                }
-               
+
                return true;
        }
 };
 
 class ModuleBanRedirect : public Module
 {
-       BanRedirect* re;
+       BanRedirect re;
        bool nofollow;
-       Module* ExceptionModule;
 
  public:
-       ModuleBanRedirect(InspIRCd* Me)
-       : Module(Me)
+       ModuleBanRedirect()
+       : re(this)
        {
-               re = new BanRedirect(Me);
                nofollow = false;
-               
-               if(!ServerInstance->Modes->AddModeWatcher(re))
-               {
-                       delete re;
-                       throw ModuleException("Could not add mode watcher");
-               }
-
-               OnRehash(NULL, "");
+       }
 
-               Implementation list[] = { I_OnRehash, I_OnUserPreJoin, I_OnChannelDelete, I_OnCleanup };
-               Me->Modules->Attach(list, this, 4);
 
-       }
-       
-       virtual void OnChannelDelete(Channel* chan)
+       void init() CXX11_OVERRIDE
        {
-               OnCleanup(TYPE_CHANNEL, chan);
+               ServerInstance->Modes->AddModeWatcher(&re);
+               ServerInstance->Modules->AddService(re.extItem);
+               Implementation list[] = { I_OnUserPreJoin };
+               ServerInstance->Modules->Attach(list, this, sizeof(list)/sizeof(Implementation));
        }
-       
-       virtual void OnCleanup(int target_type, void* item)
+
+       void OnCleanup(int target_type, void* item) CXX11_OVERRIDE
        {
                if(target_type == TYPE_CHANNEL)
                {
                        Channel* chan = static_cast<Channel*>(item);
-                       BanRedirectList* redirects;
-                       
-                       if(chan->GetExt("banredirects", redirects))
+                       BanRedirectList* redirects = re.extItem.get(chan);
+
+                       if(redirects)
                        {
                                irc::modestacker modestack(false);
-                               StringDeque stackresult;
-                               std::vector<std::string> mode_junk;
-                               mode_junk.push_back(chan->name);
-                               
+
                                for(BanRedirectList::iterator i = redirects->begin(); i != redirects->end(); i++)
                                {
                                        modestack.Push('b', i->targetchan.insert(0, i->banmask));
                                }
-                               
+
                                for(BanRedirectList::iterator i = redirects->begin(); i != redirects->end(); i++)
                                {
                                        modestack.PushPlus();
                                        modestack.Push('b', i->banmask);
                                }
-                               
-                               while(modestack.GetStackedLine(stackresult))
+
+                               std::vector<std::string> stackresult;
+                               stackresult.push_back(chan->name);
+                               while (modestack.GetStackedLine(stackresult))
                                {
-                                       for(StringDeque::size_type i = 0; i < stackresult.size(); i++)
-                                       {
-                                               mode_junk.push_back(stackresult[i]);
-                                       }
-                                       
-                                       ServerInstance->SendMode(mode_junk, ServerInstance->FakeClient);
+                                       ServerInstance->Modes->Process(stackresult, ServerInstance->FakeClient, ModeParser::MODE_LOCALONLY);
+                                       stackresult.erase(stackresult.begin() + 1, stackresult.end());
                                }
-                               
-                               delete redirects;
-                               chan->Shrink("banredirects");
                        }
                }
        }
 
-       virtual void OnRehash(User* user, const std::string &param)
-       {
-               ExceptionModule = ServerInstance->Modules->Find("m_banexception.so");
-       }
-
-       virtual int OnUserPreJoin(User* user, Channel* chan, const char* cname, std::string &privs, const std::string &keygiven)
+       ModResult OnUserPreJoin(LocalUser* user, Channel* chan, const std::string& cname, std::string& privs, const std::string& keygiven) CXX11_OVERRIDE
        {
-               /* This prevents recursion when a user sets multiple ban redirects in a chain
-                * (thanks Potter)
-                */
-               if (nofollow)
-                       return 0;
-
-               /* Return 1 to prevent the join, 0 to allow it */
                if (chan)
                {
-                       BanRedirectList* redirects;
-                       
-                       if(chan->GetExt("banredirects", redirects))
+                       BanRedirectList* redirects = re.extItem.get(chan);
+
+                       if (redirects)
                        {
                                /* We actually had some ban redirects to check */
-                               
+
                                /* This was replaced with user->MakeHostIP() when I had a snprintf(), but MakeHostIP() doesn't seem to add the nick.
                                 * Maybe we should have a GetFullIPHost() or something to match GetFullHost() and GetFullRealHost?
                                 */
 
-                               if (ExceptionModule)
+                               ModResult result;
+                               FIRST_MOD_RESULT(OnCheckChannelBan, result, (user, chan));
+                               if (result == MOD_RES_ALLOW)
                                {
-                                       ListModeRequest n(this, ExceptionModule, user, chan);
-                                       /* Users with ban exceptions are allowed to join without being redirected */
-                                       if (n.Send())
-                                               return 0;
+                                       // they have a ban exception
+                                       return MOD_RES_PASSTHRU;
                                }
 
                                std::string ipmask(user->nick);
                                ipmask.append(1, '!').append(user->MakeHostIP());
-                               
+
                                for(BanRedirectList::iterator redir = redirects->begin(); redir != redirects->end(); redir++)
                                {
-                                       if(ServerInstance->MatchText(user->GetFullRealHost(), redir->banmask) || ServerInstance->MatchText(user->GetFullHost(), redir->banmask) || ServerInstance->MatchText(ipmask, redir->banmask))
+                                       if(InspIRCd::Match(user->GetFullRealHost(), redir->banmask) || InspIRCd::Match(user->GetFullHost(), redir->banmask) || InspIRCd::MatchCIDR(ipmask, redir->banmask))
                                        {
+                                               /* This prevents recursion when a user sets multiple ban redirects in a chain
+                                                * (thanks Potter)
+                                                *
+                                                * If we're here and nofollow is true then we're already redirecting this user
+                                                * and there's a redirecting ban set on this channel that matches him, too.
+                                                * Deny both joins.
+                                                */
+                                               if (nofollow)
+                                                       return MOD_RES_DENY;
+
                                                /* tell them they're banned and are being transferred */
                                                Channel* destchan = ServerInstance->FindChan(redir->targetchan);
-                                               
-                                               if(destchan && ServerInstance->Modules->Find("m_redirect.so") && destchan->IsModeSet('L') && destchan->limit && (destchan->GetUserCounter() >= destchan->limit))
+                                               std::string destlimit;
+
+                                               if (destchan)
+                                                       destlimit = destchan->GetModeParameter('l');
+
+                                               if(destchan && ServerInstance->Modules->Find("m_redirect.so") && destchan->IsModeSet('L') && !destlimit.empty() && (destchan->GetUserCounter() >= atoi(destlimit.c_str())))
                                                {
                                                        user->WriteNumeric(474, "%s %s :Cannot join channel (You are banned)", user->nick.c_str(), chan->name.c_str());
-                                                       return 1;
+                                                       return MOD_RES_DENY;
                                                }
                                                else
                                                {
                                                        user->WriteNumeric(474, "%s %s :Cannot join channel (You are banned)", user->nick.c_str(), chan->name.c_str());
-                                                       user->WriteNumeric(470, "%s :You are being automatically redirected to %s", user->nick.c_str(), redir->targetchan.c_str());
+                                                       user->WriteNumeric(470, "%s %s %s :You are banned from this channel, so you are automatically transfered to the redirected channel.", user->nick.c_str(), chan->name.c_str(), redir->targetchan.c_str());
                                                        nofollow = true;
-                                                       Channel::JoinUser(ServerInstance, user, redir->targetchan.c_str(), false, "", false, ServerInstance->Time());
+                                                       Channel::JoinUser(user, redir->targetchan);
                                                        nofollow = false;
-                                                       return 1;
+                                                       return MOD_RES_DENY;
                                                }
                                        }
                                }
                        }
                }
-               return 0;
+               return MOD_RES_PASSTHRU;
        }
 
-       virtual ~ModuleBanRedirect()
-       {
-               ServerInstance->Modes->DelModeWatcher(re);
-               delete re;
-       }
-       
-       virtual Version GetVersion()
+       ~ModuleBanRedirect()
        {
-               return Version(1, 0, 0, 0, VF_COMMON | VF_VENDOR, API_VERSION);
+               /* XXX is this the best place to do this? */
+               if (!ServerInstance->Modes->DelModeWatcher(&re))
+                       ServerInstance->Logs->Log("m_banredirect.so", LOG_DEBUG, "Failed to delete modewatcher!");
        }
-       
-       void Prioritize()
+
+       Version GetVersion() CXX11_OVERRIDE
        {
-               Module* banex = ServerInstance->Modules->Find("m_banexception.so");
-               ServerInstance->Modules->SetPriority(this, I_OnUserPreJoin, PRIO_BEFORE, &banex);
+               return Version("Allows an extended ban (+b) syntax redirecting banned users to another channel", VF_COMMON|VF_VENDOR);
        }
 };