]> git.netwichtig.de Git - user/henk/code/inspircd.git/blobdiff - src/modules/m_services_account.cpp
Only assign NewServices once the duplicate check is done.
[user/henk/code/inspircd.git] / src / modules / m_services_account.cpp
index 3d32e315673f037b52dade59f77a2aeebafdfe7b..53d1a473037cc149891460c6ee9591d3de70b173 100644 (file)
@@ -1 +1,334 @@
-/*       +------------------------------------+\r *       | Inspire Internet Relay Chat Daemon |\r *       +------------------------------------+\r *\r *  InspIRCd: (C) 2002-2007 InspIRCd Development Team\r * See: http://www.inspircd.org/wiki/index.php/Credits\r *\r * This program is free but copyrighted software; see\r *            the file COPYING for details.\r *\r * ---------------------------------------------------\r */\r\r#include "inspircd.h"\r#include "users.h"\r#include "channels.h"\r#include "modules.h"\r#include "hashcomp.h"\r\r/* $ModDesc: Povides support for ircu-style services accounts, including chmode +R, etc. */\r\r/** Channel mode +R - unidentified users cannot join\r */\rclass AChannel_R : public ModeHandler\r{\r public:\r AChannel_R(InspIRCd* Instance) : ModeHandler(Instance, 'R', 0, 0, false, MODETYPE_CHANNEL, false) { }\r\r ModeAction OnModeChange(userrec* source, userrec* dest, chanrec* channel, std::string &parameter, bool adding)\r {\r              if (adding)\r            {\r                      if (!channel->IsModeSet('R'))\r                  {\r                              channel->SetMode('R',true);\r                            return MODEACTION_ALLOW;\r                       }\r              }\r              else\r           {\r                      if (channel->IsModeSet('R'))\r                   {\r                              channel->SetMode('R',false);\r                           return MODEACTION_ALLOW;\r                       }\r              }\r\r             return MODEACTION_DENY;\r        }\r};\r\r/** User mode +R - unidentified users cannot message\r */\rclass AUser_R : public ModeHandler\r{\r public:\r   AUser_R(InspIRCd* Instance) : ModeHandler(Instance, 'R', 0, 0, false, MODETYPE_USER, false) { }\r\r       ModeAction OnModeChange(userrec* source, userrec* dest, chanrec* channel, std::string &parameter, bool adding)\r {\r              if (adding)\r            {\r                      if (!dest->IsModeSet('R'))\r                     {\r                              dest->SetMode('R',true);\r                               return MODEACTION_ALLOW;\r                       }\r              }\r              else\r           {\r                      if (dest->IsModeSet('R'))\r                      {\r                              dest->SetMode('R',false);\r                              return MODEACTION_ALLOW;\r                       }\r              }\r\r             return MODEACTION_DENY;\r        }\r};\r\r/** Channel mode +M - unidentified users cannot message channel\r */\rclass AChannel_M : public ModeHandler\r{\r public:\r     AChannel_M(InspIRCd* Instance) : ModeHandler(Instance, 'M', 0, 0, false, MODETYPE_CHANNEL, false) { }\r\r ModeAction OnModeChange(userrec* source, userrec* dest, chanrec* channel, std::string &parameter, bool adding)\r {\r              if (adding)\r            {\r                      if (!channel->IsModeSet('M'))\r                  {\r                              channel->SetMode('M',true);\r                            return MODEACTION_ALLOW;\r                       }\r              }\r              else\r           {\r                      if (channel->IsModeSet('M'))\r                   {\r                              channel->SetMode('M',false);\r                           return MODEACTION_ALLOW;\r                       }\r              }\r\r             return MODEACTION_DENY;\r        }\r};\r\rclass ModuleServicesAccount : public Module\r{\r     \r      AChannel_R* m1;\r        AChannel_M* m2;\r        AUser_R* m3;\r public:\r  ModuleServicesAccount(InspIRCd* Me) : Module(Me)\r       {\r              \r               m1 = new AChannel_R(ServerInstance);\r           m2 = new AChannel_M(ServerInstance);\r           m3 = new AUser_R(ServerInstance);\r              if (!ServerInstance->AddMode(m1, 'R') || !ServerInstance->AddMode(m2, 'M') || !ServerInstance->AddMode(m3, 'R'))\r                       throw ModuleException("Could not add new modes!");\r     }\r\r     /* <- :twisted.oscnet.org 330 w00t2 w00t2 w00t :is logged in as */\r     virtual void OnWhois(userrec* source, userrec* dest)\r   {\r              std::string *account;\r          dest->GetExt("accountname", account);\r\r         if (account)\r           {\r                      ServerInstance->SendWhoisLine(source, dest, 330, "%s %s %s :is logged in as", source->nick, dest->nick, account->c_str());\r             }\r      }\r\r     void Implements(char* List)\r    {\r              List[I_OnWhois] = List[I_OnUserPreMessage] = List[I_OnUserPreNotice] = List[I_OnUserPreJoin] = 1;\r              List[I_OnSyncUserMetaData] = List[I_OnUserQuit] = List[I_OnCleanup] = List[I_OnDecodeMetaData] = 1;\r    }\r\r     virtual int OnUserPreMessage(userrec* user,void* dest,int target_type, std::string &text, char status, CUList &exempt_list)\r    {\r              std::string *account;\r\r         if (!IS_LOCAL(user))\r                   return 0;\r\r             user->GetExt("accountname", account);\r          \r               if (target_type == TYPE_CHANNEL)\r               {\r                      chanrec* c = (chanrec*)dest;\r                   \r                       if ((c->IsModeSet('M')) && (!account))\r                 {\r                              if ((ServerInstance->ULine(user->nick)) || (ServerInstance->ULine(user->server)))\r                              {\r                                      // user is ulined, can speak regardless\r                                        return 0;\r                              }\r\r                             // user messaging a +M channel and is not registered\r                           user->WriteServ("477 "+std::string(user->nick)+" "+std::string(c->name)+" :You need to be identified to a registered account to message this channel");\r                                return 1;\r                      }\r              }\r              if (target_type == TYPE_USER)\r          {\r                      userrec* u = (userrec*)dest;\r                   \r                       if ((u->modes['R'-65]) && (!account))\r                  {\r                              if ((ServerInstance->ULine(user->nick)) || (ServerInstance->ULine(user->server)))\r                              {\r                                      // user is ulined, can speak regardless\r                                        return 0;\r                              }\r\r                             // user messaging a +R user and is not registered\r                              user->WriteServ("477 "+std::string(user->nick)+" "+std::string(u->nick)+" :You need to be identified to a registered account to message this user");\r                           return 1;\r                      }\r              }\r              return 0;\r      }\r       \r      virtual int OnUserPreNotice(userrec* user,void* dest,int target_type, std::string &text, char status, CUList &exempt_list)\r     {\r              return OnUserPreMessage(user, dest, target_type, text, status, exempt_list);\r   }\r       \r      virtual int OnUserPreJoin(userrec* user, chanrec* chan, const char* cname, std::string &privs)\r {\r              std::string *account;\r          user->GetExt("accountname", account);\r          \r               if (chan)\r              {\r                      if (chan->IsModeSet('R'))\r                      {\r                              if (!account)\r                          {\r                                      if ((ServerInstance->ULine(user->nick)) || (ServerInstance->ULine(user->server)))\r                                      {\r                                              // user is ulined, won't be stopped from joining\r                                               return 0;\r                                      }\r                                      // joining a +R channel and not identified\r                                     user->WriteServ("477 "+std::string(user->nick)+" "+std::string(chan->name)+" :You need to be identified to a registered account to join this channel");\r                                        return 1;\r                              }\r                      }\r              }\r              return 0;\r      }\r      \r       // Whenever the linking module wants to send out data, but doesnt know what the data\r   // represents (e.g. it is metadata, added to a userrec or chanrec by a module) then\r    // this method is called. We should use the ProtoSendMetaData function after we've\r     // corrected decided how the data should look, to send the metadata on its way if\r      // it is ours.\r virtual void OnSyncUserMetaData(userrec* user, Module* proto, void* opaque, const std::string &extname, bool displayable)\r      {\r              // check if the linking module wants to know about OUR metadata\r                if (extname == "accountname")\r          {\r                      // check if this user has an swhois field to send\r                      std::string* account;\r                  user->GetExt("accountname", account);\r                  if (account)\r                   {\r                              // remove any accidental leading/trailing spaces\r                               trim(*account);\r\r                               // call this function in the linking module, let it format the data how it\r                             // sees fit, and send it on its way. We dont need or want to know how.\r                         proto->ProtoSendMetaData(opaque,TYPE_USER,user,extname,*account);\r                      }\r              }\r      }\r\r     // when a user quits, tidy up their metadata\r   virtual void OnUserQuit(userrec* user, const std::string &message, const std::string &oper_message)\r    {\r              std::string* account;\r          user->GetExt("accountname", account);\r          if (account)\r           {\r                      user->Shrink("accountname");\r                   delete account;\r                }\r      }\r\r     // if the module is unloaded, tidy up all our dangling metadata\r        virtual void OnCleanup(int target_type, void* item)\r    {\r              if (target_type == TYPE_USER)\r          {\r                      userrec* user = (userrec*)item;\r                        std::string* account;\r                  user->GetExt("accountname", account);\r                  if (account)\r                   {\r                              user->Shrink("accountname");\r                           delete account;\r                        }\r              }\r      }\r\r     // Whenever the linking module receives metadata from another server and doesnt know what\r      // to do with it (of course, hence the 'meta') it calls this method, and it is up to each\r      // module in turn to figure out if this metadata key belongs to them, and what they want\r       // to do with it.\r      // In our case we're only sending a single string around, so we just construct a std::string.\r  // Some modules will probably get much more complex and format more detailed structs and classes\r       // in a textual way for sending over the link.\r virtual void OnDecodeMetaData(int target_type, void* target, const std::string &extname, const std::string &extdata)\r   {\r              // check if its our metadata key, and its associated with a user\r               if ((target_type == TYPE_USER) && (extname == "accountname"))\r          {       \r                       userrec* dest = (userrec*)target;\r                      \r                       /* logging them out? */\r                        if (extdata.empty())\r                   {\r                              std::string* account;\r                          dest->GetExt("accountname", account);\r                          if (account)\r                           {\r                                      dest->Shrink("accountname");\r                                   delete account;\r                                }\r                      }\r                      else\r                   {\r                              // if they dont already have an accountname field, accept the remote server's\r                          std::string* text;\r                             if (!dest->GetExt("accountname", text))\r                                {\r                                      text = new std::string(extdata);\r                                       // remove any accidental leading/trailing spaces\r                                       trim(*text);\r                                   dest->Extend("accountname", text);\r                             }\r                      }\r              }\r      }\r\r     virtual ~ModuleServicesAccount()\r       {\r              ServerInstance->Modes->DelMode(m1);\r            ServerInstance->Modes->DelMode(m2);\r            ServerInstance->Modes->DelMode(m3);\r            DELETE(m1);\r            DELETE(m2);\r            DELETE(m3);\r    }\r      \r       virtual Version GetVersion()\r   {\r              return Version(1,1,0,0,VF_COMMON|VF_VENDOR,API_VERSION);\r       }\r};\r\rMODULE_INIT(ModuleServicesAccount)\r
\ No newline at end of file
+/*
+ * InspIRCd -- Internet Relay Chat Daemon
+ *
+ *   Copyright (C) 2019 linuxdaemon <linuxdaemon.irc@gmail.com>
+ *   Copyright (C) 2013, 2017-2020 Sadie Powell <sadie@witchery.services>
+ *   Copyright (C) 2012-2015 Attila Molnar <attilamolnar@hush.com>
+ *   Copyright (C) 2012, 2019 Robby <robby@chatbelgie.be>
+ *   Copyright (C) 2012 Shawn Smith <ShawnSmith0828@gmail.com>
+ *   Copyright (C) 2009-2010 Daniel De Graaf <danieldg@inspircd.org>
+ *   Copyright (C) 2009 Uli Schlachter <psychon@inspircd.org>
+ *   Copyright (C) 2008 Robin Burchell <robin+git@viroteck.net>
+ *   Copyright (C) 2007 Dennis Friis <peavey@inspircd.org>
+ *   Copyright (C) 2006, 2008 Craig Edwards <brain@inspircd.org>
+ *
+ * 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 "modules/account.h"
+#include "modules/callerid.h"
+#include "modules/ctctags.h"
+#include "modules/exemption.h"
+#include "modules/whois.h"
+
+enum
+{
+       // From UnrealIRCd.
+       RPL_WHOISREGNICK = 307,
+
+       // From ircu.
+       RPL_WHOISACCOUNT = 330,
+
+       // From ircd-hybrid?
+       ERR_NEEDREGGEDNICK = 477,
+
+       // From IRCv3 sasl-3.1.
+       RPL_LOGGEDIN = 900,
+       RPL_LOGGEDOUT = 901
+};
+
+/** Channel mode +r - mark a channel as identified
+ */
+class Channel_r : public ModeHandler
+{
+ public:
+       Channel_r(Module* Creator) : ModeHandler(Creator, "c_registered", 'r', PARAM_NONE, MODETYPE_CHANNEL) { }
+
+       ModeAction OnModeChange(User* source, User* dest, Channel* channel, std::string& parameter, bool adding) CXX11_OVERRIDE
+       {
+               // Only a U-lined server may add or remove the +r mode.
+               if (!IS_LOCAL(source))
+               {
+                       // Only change the mode if it's not redundant
+                       if ((adding != channel->IsModeSet(this)))
+                       {
+                               channel->SetMode(this, adding);
+                               return MODEACTION_ALLOW;
+                       }
+               }
+               else
+               {
+                       source->WriteNumeric(ERR_NOPRIVILEGES, "Only a server may modify the +r channel mode");
+               }
+               return MODEACTION_DENY;
+       }
+};
+
+/** User mode +r - mark a user as identified
+ */
+class User_r : public ModeHandler
+{
+
+ public:
+       User_r(Module* Creator) : ModeHandler(Creator, "u_registered", 'r', PARAM_NONE, MODETYPE_USER) { }
+
+       ModeAction OnModeChange(User* source, User* dest, Channel* channel, std::string& parameter, bool adding) CXX11_OVERRIDE
+       {
+               if (!IS_LOCAL(source))
+               {
+                       if ((adding != dest->IsModeSet(this)))
+                       {
+                               dest->SetMode(this, adding);
+                               return MODEACTION_ALLOW;
+                       }
+               }
+               else
+               {
+                       source->WriteNumeric(ERR_NOPRIVILEGES, "Only a server may modify the +r user mode");
+               }
+               return MODEACTION_DENY;
+       }
+};
+
+class AccountExtItemImpl : public AccountExtItem
+{
+       Events::ModuleEventProvider eventprov;
+
+ public:
+       AccountExtItemImpl(Module* mod)
+               : AccountExtItem("accountname", ExtensionItem::EXT_USER, mod)
+               , eventprov(mod, "event/account")
+       {
+       }
+
+       void FromInternal(Extensible* container, const std::string& value) CXX11_OVERRIDE
+       {
+               StringExtItem::FromInternal(container, value);
+       }
+
+       void FromNetwork(Extensible* container, const std::string& value) CXX11_OVERRIDE
+       {
+               StringExtItem::FromNetwork(container, value);
+
+               User* user = static_cast<User*>(container);
+               if (IS_LOCAL(user))
+               {
+                       if (value.empty())
+                       {
+                               // Logged out.
+                               user->WriteNumeric(RPL_LOGGEDOUT, user->GetFullHost(), "You are now logged out");
+                       }
+                       else
+                       {
+                               // Logged in.
+                               user->WriteNumeric(RPL_LOGGEDIN, user->GetFullHost(), value, InspIRCd::Format("You are now logged in as %s", value.c_str()));
+                       }
+               }
+
+               FOREACH_MOD_CUSTOM(eventprov, AccountEventListener, OnAccountChange, (user, value));
+       }
+};
+
+class ModuleServicesAccount
+       : public Module
+       , public Whois::EventListener
+       , public CTCTags::EventListener
+{
+ private:
+       CallerID::API calleridapi;
+       CheckExemption::EventProvider exemptionprov;
+       SimpleChannelModeHandler reginvitemode;
+       SimpleChannelModeHandler regmoderatedmode;
+       SimpleUserModeHandler regdeafmode;
+       Channel_r chanregmode;
+       User_r userregmode;
+       AccountExtItemImpl accountname;
+       bool checking_ban;
+
+ public:
+       ModuleServicesAccount()
+               : Whois::EventListener(this)
+               , CTCTags::EventListener(this)
+               , calleridapi(this)
+               , exemptionprov(this)
+               , reginvitemode(this, "reginvite", 'R')
+               , regmoderatedmode(this, "regmoderated", 'M')
+               , regdeafmode(this, "regdeaf", 'R')
+               , chanregmode(this)
+               , userregmode(this)
+               , accountname(this)
+               , checking_ban(false)
+       {
+       }
+
+       void On005Numeric(std::map<std::string, std::string>& tokens) CXX11_OVERRIDE
+       {
+               tokens["EXTBAN"].push_back('R');
+               tokens["EXTBAN"].push_back('U');
+       }
+
+       /* <- :twisted.oscnet.org 330 w00t2 w00t2 w00t :is logged in as */
+       void OnWhois(Whois::Context& whois) CXX11_OVERRIDE
+       {
+               std::string* account = accountname.get(whois.GetTarget());
+
+               if (account)
+               {
+                       whois.SendLine(RPL_WHOISACCOUNT, *account, "is logged in as");
+               }
+
+               if (whois.GetTarget()->IsModeSet(userregmode))
+               {
+                       /* user is registered */
+                       whois.SendLine(RPL_WHOISREGNICK, "is a registered nick");
+               }
+       }
+
+       void OnUserPostNick(User* user, const std::string &oldnick) CXX11_OVERRIDE
+       {
+               /* On nickchange, if they have +r, remove it */
+               if ((user->IsModeSet(userregmode)) && (ServerInstance->FindNickOnly(oldnick) != user))
+                       userregmode.RemoveMode(user);
+       }
+
+       ModResult HandleMessage(User* user, const MessageTarget& target)
+       {
+               if (!IS_LOCAL(user))
+                       return MOD_RES_PASSTHRU;
+
+               std::string *account = accountname.get(user);
+               bool is_registered = account && !account->empty();
+
+               switch (target.type)
+               {
+                       case MessageTarget::TYPE_CHANNEL:
+                       {
+                               Channel* targchan = target.Get<Channel>();
+
+                               if (!targchan->IsModeSet(regmoderatedmode) || is_registered)
+                                       return MOD_RES_PASSTHRU;
+
+                               if (CheckExemption::Call(exemptionprov, user, targchan, "regmoderated") == MOD_RES_ALLOW)
+                                       return MOD_RES_PASSTHRU;
+
+                               // User is messaging a +M channel and is not registered or exempt.
+                               user->WriteNumeric(ERR_NEEDREGGEDNICK, targchan->name, "You need to be identified to a registered account to message this channel");
+                               return MOD_RES_DENY;
+                               break;
+                       }
+                       case MessageTarget::TYPE_USER:
+                       {
+                               User* targuser = target.Get<User>();
+                               if (!targuser->IsModeSet(regdeafmode)  || is_registered)
+                                       return MOD_RES_PASSTHRU;
+
+                               if (calleridapi && calleridapi->IsOnAcceptList(user, targuser))
+                                       return MOD_RES_PASSTHRU;
+
+                               // User is messaging a +R user and is not registered or on an accept list.
+                               user->WriteNumeric(ERR_NEEDREGGEDNICK, targuser->nick, "You need to be identified to a registered account to message this user");
+                               return MOD_RES_DENY;
+                               break;
+                       }
+                       case MessageTarget::TYPE_SERVER:
+                               break;
+               }
+               return MOD_RES_PASSTHRU;
+       }
+
+       ModResult OnUserPreMessage(User* user, const MessageTarget& target, MessageDetails& details) CXX11_OVERRIDE
+       {
+               return HandleMessage(user, target);
+       }
+
+       ModResult OnUserPreTagMessage(User* user, const MessageTarget& target, CTCTags::TagMessageDetails& details) CXX11_OVERRIDE
+       {
+               return HandleMessage(user, target);
+       }
+
+       ModResult OnCheckBan(User* user, Channel* chan, const std::string& mask) CXX11_OVERRIDE
+       {
+               if (checking_ban)
+                       return MOD_RES_PASSTHRU;
+
+               if ((mask.length() > 2) && (mask[1] == ':'))
+               {
+                       if (mask[0] == 'R')
+                       {
+                               std::string *account = accountname.get(user);
+                               if (account && InspIRCd::Match(*account, mask.substr(2)))
+                                       return MOD_RES_DENY;
+                       }
+                       else if (mask[0] == 'U')
+                       {
+                               std::string *account = accountname.get(user);
+                               /* If the user is registered we don't care. */
+                               if (account)
+                                       return MOD_RES_PASSTHRU;
+
+                               /* If we made it this far we know the user isn't registered
+                                       so just deny if it matches */
+                               checking_ban = true;
+                               bool result = chan->CheckBan(user, mask.substr(2));
+                               checking_ban = false;
+
+                               if (result)
+                                       return MOD_RES_DENY;
+                       }
+               }
+
+               /* If we made it this far then the ban wasn't an ExtBan
+                       or the user we were checking for didn't match either ExtBan */
+               return MOD_RES_PASSTHRU;
+       }
+
+       ModResult OnUserPreJoin(LocalUser* user, Channel* chan, const std::string& cname, std::string& privs, const std::string& keygiven) CXX11_OVERRIDE
+       {
+               std::string *account = accountname.get(user);
+               bool is_registered = account && !account->empty();
+
+               if (chan)
+               {
+                       if (chan->IsModeSet(reginvitemode))
+                       {
+                               if (!is_registered)
+                               {
+                                       // joining a +R channel and not identified
+                                       user->WriteNumeric(ERR_NEEDREGGEDNICK, chan->name, "You need to be identified to a registered account to join this channel");
+                                       return MOD_RES_DENY;
+                               }
+                       }
+               }
+               return MOD_RES_PASSTHRU;
+       }
+
+       ModResult OnSetConnectClass(LocalUser* user, ConnectClass* myclass) CXX11_OVERRIDE
+       {
+               if (myclass->config->getBool("requireaccount") && !accountname.get(user))
+               {
+                       ServerInstance->Logs->Log("CONNECTCLASS", LOG_DEBUG, "The %s connect class is not suitable as it requires the user to be logged into an account",
+                               myclass->GetName().c_str());
+                       return MOD_RES_DENY;
+               }
+               return MOD_RES_PASSTHRU;
+       }
+
+       Version GetVersion() CXX11_OVERRIDE
+       {
+               return Version("Adds various channel and user modes relating to services accounts.", VF_OPTCOMMON|VF_VENDOR);
+       }
+};
+
+MODULE_INIT(ModuleServicesAccount)