src/modules/m_cban.cpp

   1 /*      +------------------------------------+
   2  *      | Inspire Internet Relay Chat Daemon |
   3  *      +------------------------------------+
   4  *
   5  * InspIRCd is copyright (C) 2002-2006 ChatSpike-Dev.
   6  *                    E-mail:
   7  *              <brain@chatspike.net>
   8  *              <Craig@chatspike.net>
   9  *                <omster@gmail.com>
  10  *
  11  * Written by Craig Edwards, Craig McLure, and others.
  12  * This program is free but copyrighted software; see
  13  * the file COPYING for details.
  14  *
  15  * ---------------------------------------------------
  16  */
  17
  18 #include <algorithm>
  19 #include "users.h"
  20 #include "channels.h"
  21 #include "modules.h"
  22 #include "configreader.h"
  23 #include "inspircd.h"
  24
  25 /* $ModDesc: Gives /cban, aka C:lines. Think Q:lines, for channels. */
  26
  27 /** Holds a CBAN item
  28  */
  29 class CBan : public classbase
  30 {
  31 public:
  32         irc::string chname;
  33         std::string set_by;
  34         time_t set_on;
  35         long length;
  36         std::string reason;
  37
  38         CBan()
  39         {
  40         }
  41
  42         CBan(irc::string cn, std::string sb, time_t so, long ln, std::string rs) : chname(cn), set_by(sb), set_on(so), length(ln), reason(rs)
  43         {
  44         }
  45 };
  46
  47 bool CBanComp(const CBan &ban1, const CBan &ban2);
  48
  49 typedef std::vector<CBan> cbanlist;
  50
  51 /* cbans is declared here, as our type is right above. Don't try move it. */
  52 cbanlist cbans;
  53
  54 class cmd_cban : public command_t
  55 {
  56  public:
  57         cmd_cban(InspIRCd* Me) : command_t(Me, "CBAN", 'o', 1)
  58         {
  59                 this->source = "m_cban.so";
  60                 this->
  61                 syntax = "<channel> [<duration> :<reason>]";
  62         }
  63
  64         CmdResult Handle(const char** parameters, int pcnt, userrec *user)
  65         {
  66                 /* syntax: CBAN #channel time :reason goes here */
  67                 /* 'time' is a human-readable timestring, like 2d3h2s. */
  68
  69                 if(pcnt == 1)
  70                 {
  71                         /* form: CBAN #channel removes a CBAN */
  72                         for (cbanlist::iterator iter = cbans.begin(); iter != cbans.end(); iter++)
  73                         {
  74                                 if (parameters[0] == iter->chname)
  75                                 {
  76                                         unsigned long remaining = (iter->set_on + iter->length) - ServerInstance->Time();
  77                                         user->WriteServ( "386 %s %s :Removed CBAN with %lu seconds left before expiry (%s)", user->nick, iter->chname.c_str(), remaining, iter->reason.c_str());
  78                                         cbans.erase(iter);
  79                                         break;
  80                                 }
  81                         }
  82                 }
  83                 else if (pcnt >= 2)
  84                 {
  85                         /* full form to add a CBAN */
  86                         if (ServerInstance->IsChannel(parameters[0]))
  87                         {
  88                                 // parameters[0] = #channel
  89                                 // parameters[1] = 1h3m2s
  90                                 // parameters[2] = Tortoise abuser
  91                                 long length = ServerInstance->Duration(parameters[1]);
  92                                 std::string reason = (pcnt > 2) ? parameters[2] : "No reason supplied";
  93
  94                                 cbans.push_back(CBan(parameters[0], user->nick, ServerInstance->Time(), length, reason));
  95
  96                                 std::sort(cbans.begin(), cbans.end(), CBanComp);
  97
  98                                 if(length > 0)
  99                                 {
 100                                         user->WriteServ( "385 %s %s :Added %lu second channel ban (%s)", user->nick, parameters[0], length, reason.c_str());
 101                                         ServerInstance->WriteOpers("*** %s added %lu second channel ban on %s (%s)", user->nick, length, parameters[0], reason.c_str());
 102                                 }
 103                                 else
 104                                 {
 105                                         user->WriteServ( "385 %s %s :Added permenant channel ban (%s)", user->nick, parameters[0], reason.c_str());
 106                                         ServerInstance->WriteOpers("*** %s added permenant channel ban on %s (%s)", user->nick, parameters[0], reason.c_str());
 107                                 }
 108                         }
 109                         else
 110                         {
 111                                 user->WriteServ( "403 %s %s :Invalid channel name", user->nick, parameters[0]);
 112                                 return CMD_FAILURE;
 113                         }
 114                 }
 115
 116                 return CMD_SUCCESS;
 117         }
 118 };
 119
 120 bool CBanComp(const CBan &ban1, const CBan &ban2)
 121 {
 122         return ((ban1.set_on + ban1.length) < (ban2.set_on + ban2.length));
 123 }
 124
 125 class ModuleCBan : public Module
 126 {
 127         cmd_cban* mycommand;
 128
 129
 130  public:
 131         ModuleCBan(InspIRCd* Me) : Module::Module(Me)
 132         {
 133
 134                 mycommand = new cmd_cban(Me);
 135                 ServerInstance->AddCommand(mycommand);
 136         }
 137
 138         void Implements(char* List)
 139         {
 140                 List[I_OnUserPreJoin] = List[I_OnSyncOtherMetaData] = List[I_OnDecodeMetaData] = List[I_OnStats] = 1;
 141         }
 142
 143         virtual int OnStats(char symbol, userrec* user, string_list &results)
 144         {
 145                 ExpireBans();
 146
 147                 if(symbol == 'C')
 148                 {
 149                         for(cbanlist::iterator iter = cbans.begin(); iter != cbans.end(); iter++)
 150                         {
 151                                 unsigned long remaining = (iter->set_on + iter->length) - ServerInstance->Time();
 152                                 results.push_back(std::string(ServerInstance->Config->ServerName)+" 210 "+user->nick+" "+iter->chname.c_str()+" "+iter->set_by+" "+ConvToStr(iter->set_on)+" "+ConvToStr(iter->length)+" "+ConvToStr(remaining)+" :"+iter->reason);
 153                         }
 154                 }
 155
 156                 return 0;
 157         }
 158
 159         virtual int OnUserPreJoin(userrec *user, chanrec *chan, const char *cname)
 160         {
 161                 ExpireBans();
 162
 163                 /* check cbans in here, and apply as necessary. */
 164                 for(cbanlist::iterator iter = cbans.begin(); iter != cbans.end(); iter++)
 165                 {
 166                         if(iter->chname == cname && !user->modes[UM_OPERATOR])
 167                         {
 168                                 // Channel is banned.
 169                                 user->WriteServ( "384 %s %s :Cannot join channel, CBANed (%s)", user->nick, cname, iter->reason.c_str());
 170                                 ServerInstance->WriteOpers("*** %s tried to join %s which is CBANed (%s)", user->nick, cname, iter->reason.c_str());
 171                                 return 1;
 172                         }
 173                 }
 174                 return 0;
 175         }
 176
 177         virtual void OnSyncOtherMetaData(Module* proto, void* opaque)
 178         {
 179                 for(cbanlist::iterator iter = cbans.begin(); iter != cbans.end(); iter++)
 180                 {
 181                         proto->ProtoSendMetaData(opaque, TYPE_OTHER, NULL, "cban", EncodeCBan(*iter));
 182                 }
 183         }
 184
 185         virtual void OnDecodeMetaData(int target_type, void* target, const std::string &extname, const std::string &extdata)
 186         {
 187                 if((target_type == TYPE_OTHER) && (extname == "cban"))
 188                 {
 189                         cbans.push_back(DecodeCBan(extdata));
 190                         std::sort(cbans.begin(), cbans.end(), CBanComp);
 191                 }
 192         }
 193
 194         virtual ~ModuleCBan()
 195         {
 196         }
 197
 198         virtual Version GetVersion()
 199         {
 200                 return Version(1,0,0,1,VF_VENDOR);
 201         }
 202
 203         std::string EncodeCBan(const CBan &ban)
 204         {
 205                 std::ostringstream stream;
 206                 stream << ban.chname << " " << ban.set_by << " " << ban.set_on << " " << ban.length << " " << ban.reason;
 207                 return stream.str();
 208         }
 209
 210         CBan DecodeCBan(const std::string &data)
 211         {
 212                 CBan res;
 213                 std::istringstream stream(data);
 214                 stream >> res.chname;
 215                 stream >> res.set_by;
 216                 stream >> res.set_on;
 217                 stream >> res.length;
 218                 res.reason = stream.str();
 219
 220                 return res;
 221         }
 222
 223         void ExpireBans()
 224         {
 225                 bool go_again = true;
 226
 227                 while (go_again)
 228                 {
 229                         go_again = false;
 230
 231                         for (cbanlist::iterator iter = cbans.begin(); iter != cbans.end(); iter++)
 232                         {
 233                                 /* 0 == permanent, don't mess with them! -- w00t */
 234                                 if (iter->length != 0)
 235                                 {
 236                                         if (iter->set_on + iter->length <= ServerInstance->Time())
 237                                         {
 238                                                 ServerInstance->Log(DEBUG, "m_cban.so: Ban on %s expired, removing...", iter->chname.c_str());
 239                                                 ServerInstance->WriteOpers("*** %li second CBAN on %s (%s) set %u seconds ago expired", iter->length, iter->chname.c_str(), iter->reason.c_str(), ServerInstance->Time() - iter->set_on);
 240                                                 cbans.erase(iter);
 241                                                 go_again = true;
 242                                         }
 243                                 }
 244
 245                                 if (go_again == true)
 246                                         break;
 247                         }
 248                 }
 249         }
 250 };
 251
 252 class ModuleCBanFactory : public ModuleFactory
 253 {
 254  public:
 255         ModuleCBanFactory()
 256         {
 257         }
 258
 259         ~ModuleCBanFactory()
 260         {
 261         }
 262
 263         virtual Module * CreateModule(InspIRCd* Me)
 264         {
 265                 return new ModuleCBan(Me);
 266         }
 267
 268 };
 269
 270
 271 extern "C" void * init_module( void )
 272 {
 273         return new ModuleCBanFactory;
 274 }