src/modules.cpp

   1 /*       +------------------------------------+
   2  *       | Inspire Internet Relay Chat Daemon |
   3  *       +------------------------------------+
   4  *
   5  *  Inspire is copyright (C) 2002-2004 ChatSpike-Dev.
   6  *                       E-mail:
   7  *                <brain@chatspike.net>
   8  *                <Craig@chatspike.net>
   9  *
  10  * Written by Craig Edwards, Craig McLure, and others.
  11  * This program is free but copyrighted software; see
  12  *            the file COPYING for details.
  13  *
  14  * ---------------------------------------------------
  15  */
  16
  17 #include "inspircd.h"
  18 #include "inspircd_io.h"
  19 #include "inspircd_util.h"
  20 #include "inspircd_config.h"
  21 #include <unistd.h>
  22 #include <fcntl.h>
  23 #include <sys/errno.h>
  24 #include <sys/ioctl.h>
  25 #include <sys/utsname.h>
  26 #ifdef USE_KQUEUE
  27 #include <sys/types.h>
  28 #include <sys/event.h>
  29 #include <sys/time.h>
  30 #endif
  31 #include <cstdio>
  32 #include <time.h>
  33 #include <string>
  34 #ifdef GCC3
  35 #include <ext/hash_map>
  36 #else
  37 #include <hash_map>
  38 #endif
  39 #include <map>
  40 #include <sstream>
  41 #include <vector>
  42 #include <errno.h>
  43 #include <deque>
  44 #include <errno.h>
  45 #include <unistd.h>
  46 #include <sched.h>
  47 #include "connection.h"
  48 #include "users.h"
  49 #include "servers.h"
  50 #include "ctables.h"
  51 #include "globals.h"
  52 #include "modules.h"
  53 #include "dynamic.h"
  54 #include "wildcard.h"
  55 #include "message.h"
  56 #include "mode.h"
  57 #include "xline.h"
  58 #include "commands.h"
  59 #include "inspstring.h"
  60
  61 #ifdef GCC3
  62 #define nspace __gnu_cxx
  63 #else
  64 #define nspace std
  65 #endif
  66
  67 using namespace std;
  68
  69 #ifdef USE_KQUEUE
  70 extern int kq;
  71 #endif
  72
  73 extern int MODCOUNT;
  74 extern std::vector<Module*> modules;
  75 extern std::vector<ircd_module*> factory;
  76
  77 extern time_t TIME;
  78
  79 extern int LogLevel;
  80 extern char ServerName[MAXBUF];
  81 extern char Network[MAXBUF];
  82 extern char ServerDesc[MAXBUF];
  83 extern char AdminName[MAXBUF];
  84 extern char AdminEmail[MAXBUF];
  85 extern char AdminNick[MAXBUF];
  86 extern char diepass[MAXBUF];
  87 extern char restartpass[MAXBUF];
  88 extern char motd[MAXBUF];
  89 extern char rules[MAXBUF];
  90 extern char list[MAXBUF];
  91 extern char PrefixQuit[MAXBUF];
  92 extern char DieValue[MAXBUF];
  93
  94 extern int debugging;
  95 extern int WHOWAS_STALE;
  96 extern int WHOWAS_MAX;
  97 extern int DieDelay;
  98 extern time_t startup_time;
  99 extern int NetBufferSize;
 100 extern int MaxWhoResults;
 101 extern time_t nb_start;
 102
 103 extern std::vector<int> fd_reap;
 104 extern std::vector<std::string> module_names;
 105
 106 extern int boundPortCount;
 107 extern int portCount;
 108 extern int SERVERportCount;
 109 extern int ports[MAXSOCKS];
 110 extern int defaultRoute;
 111
 112 extern std::vector<long> auth_cookies;
 113 extern std::stringstream config_f;
 114
 115 extern serverrec* me[32];
 116
 117 extern FILE *log_file;
 118
 119 extern userrec* fd_ref_table[65536];
 120
 121 namespace nspace
 122 {
 123 #ifdef GCC34
 124         template<> struct hash<in_addr>
 125 #else
 126         template<> struct nspace::hash<in_addr>
 127 #endif
 128         {
 129                 size_t operator()(const struct in_addr &a) const
 130                 {
 131                         size_t q;
 132                         memcpy(&q,&a,sizeof(size_t));
 133                         return q;
 134                 }
 135         };
 136 #ifdef GCC34
 137         template<> struct hash<string>
 138 #else
 139         template<> struct nspace::hash<string>
 140 #endif
 141         {
 142                 size_t operator()(const string &s) const
 143                 {
 144                         char a[MAXBUF];
 145                         static struct hash<const char *> strhash;
 146                         strlcpy(a,s.c_str(),MAXBUF);
 147                         strlower(a);
 148                         return strhash(a);
 149                 }
 150         };
 151 }
 152
 153 struct StrHashComp
 154 {
 155
 156         bool operator()(const string& s1, const string& s2) const
 157         {
 158                 char a[MAXBUF],b[MAXBUF];
 159                 strlcpy(a,s1.c_str(),MAXBUF);
 160                 strlcpy(b,s2.c_str(),MAXBUF);
 161                 strlower(a);
 162                 strlower(b);
 163                 return (strcasecmp(a,b) == 0);
 164         }
 165
 166 };
 167
 168 struct InAddr_HashComp
 169 {
 170
 171         bool operator()(const in_addr &s1, const in_addr &s2) const
 172         {
 173                 size_t q;
 174                 size_t p;
 175
 176                 memcpy(&q,&s1,sizeof(size_t));
 177                 memcpy(&p,&s2,sizeof(size_t));
 178
 179                 return (q == p);
 180         }
 181
 182 };
 183
 184
 185 typedef nspace::hash_map<std::string, userrec*, nspace::hash<string>, StrHashComp> user_hash;
 186 typedef nspace::hash_map<std::string, chanrec*, nspace::hash<string>, StrHashComp> chan_hash;
 187 typedef nspace::hash_map<in_addr,string*, nspace::hash<in_addr>, InAddr_HashComp> address_cache;
 188 typedef nspace::hash_map<std::string, WhoWasUser*, nspace::hash<string>, StrHashComp> whowas_hash;
 189 typedef std::deque<command_t> command_table;
 190
 191
 192 extern user_hash clientlist;
 193 extern chan_hash chanlist;
 194 extern whowas_hash whowas;
 195 extern command_table cmdlist;
 196 extern file_cache MOTD;
 197 extern file_cache RULES;
 198 extern address_cache IP;
 199
 200
 201 // class type for holding an extended mode character - internal to core
 202
 203 class ExtMode : public classbase
 204 {
 205 public:
 206         char modechar;
 207         int type;
 208         int params_when_on;
 209         int params_when_off;
 210         bool needsoper;
 211         bool list;
 212         ExtMode(char mc, int ty, bool oper, int p_on, int p_off) : modechar(mc), type(ty), needsoper(oper), params_when_on(p_on), params_when_off(p_off) { };
 213 };
 214
 215 typedef std::vector<ExtMode> ExtModeList;
 216 typedef ExtModeList::iterator ExtModeListIter;
 217
 218
 219 ExtModeList EMode;
 220
 221 // returns true if an extended mode character is in use
 222 bool ModeDefined(char modechar, int type)
 223 {
 224         for (ExtModeListIter i = EMode.begin(); i < EMode.end(); i++)
 225         {
 226                 if ((i->modechar == modechar) && (i->type == type))
 227                 {
 228                         return true;
 229                 }
 230         }
 231         return false;
 232 }
 233
 234 bool ModeIsListMode(char modechar, int type)
 235 {
 236         for (ExtModeListIter i = EMode.begin(); i < EMode.end(); i++)
 237         {
 238                 if ((i->modechar == modechar) && (i->type == type) && (i->list == true))
 239                 {
 240                         return true;
 241                 }
 242         }
 243         return false;
 244 }
 245
 246 bool ModeDefinedOper(char modechar, int type)
 247 {
 248         for (ExtModeListIter i = EMode.begin(); i < EMode.end(); i++)
 249         {
 250                 if ((i->modechar == modechar) && (i->type == type) && (i->needsoper == true))
 251                 {
 252                         return true;
 253                 }
 254         }
 255         return false;
 256 }
 257
 258 // returns number of parameters for a custom mode when it is switched on
 259 int ModeDefinedOn(char modechar, int type)
 260 {
 261         for (ExtModeListIter i = EMode.begin(); i < EMode.end(); i++)
 262         {
 263                 if ((i->modechar == modechar) && (i->type == type))
 264                 {
 265                         return i->params_when_on;
 266                 }
 267         }
 268         return 0;
 269 }
 270
 271 // returns number of parameters for a custom mode when it is switched on
 272 int ModeDefinedOff(char modechar, int type)
 273 {
 274         for (ExtModeListIter i = EMode.begin(); i < EMode.end(); i++)
 275         {
 276                 if ((i->modechar == modechar) && (i->type == type))
 277                 {
 278                         return i->params_when_off;
 279                 }
 280         }
 281         return 0;
 282 }
 283
 284 // returns true if an extended mode character is in use
 285 bool DoAddExtendedMode(char modechar, int type, bool requires_oper, int params_on, int params_off)
 286 {
 287         if (ModeDefined(modechar,type)) {
 288                 return false;
 289         }
 290         EMode.push_back(ExtMode(modechar,type,requires_oper,params_on,params_off));
 291         return true;
 292 }
 293
 294 // turns a mode into a listmode
 295 void ModeMakeList(char modechar)
 296 {
 297         for (ExtModeListIter i = EMode.begin(); i < EMode.end(); i++)
 298         {
 299                 if ((i->modechar == modechar) && (i->type == MT_CHANNEL))
 300                 {
 301                         i->list = true;
 302                         return;
 303                 }
 304         }
 305         return;
 306 }
 307
 308 // version is a simple class for holding a modules version number
 309
 310 Version::Version(int major, int minor, int revision, int build, int flags) : Major(major), Minor(minor), Revision(revision), Build(build), Flags(flags) { };
 311
 312 // admin is a simple class for holding a server's administrative info
 313
 314 Admin::Admin(std::string name, std::string email, std::string nick) : Name(name), Email(email), Nick(nick) { };
 315
 316 Request::Request(char* anydata, Module* src, Module* dst) : data(anydata), source(src), dest(dst) { };
 317
 318 char* Request::GetData()
 319 {
 320         return this->data;
 321 }
 322
 323 Module* Request::GetSource()
 324 {
 325         return this->source;
 326 }
 327
 328 Module* Request::GetDest()
 329 {
 330         return this->dest;
 331 }
 332
 333 char* Request::Send()
 334 {
 335         if (this->dest)
 336         {
 337                 return dest->OnRequest(this);
 338         }
 339         else
 340         {
 341                 return NULL;
 342         }
 343 }
 344
 345 Event::Event(char* anydata, Module* src, std::string eventid) : data(anydata), source(src), id(eventid) { };
 346
 347 char* Event::GetData()
 348 {
 349         return this->data;
 350 }
 351
 352 Module* Event::GetSource()
 353 {
 354         return this->source;
 355 }
 356
 357 char* Event::Send()
 358 {
 359         FOREACH_MOD OnEvent(this);
 360         return NULL;
 361 }
 362
 363 std::string Event::GetEventID()
 364 {
 365         return this->id;
 366 }
 367
 368
 369 // These declarations define the behavours of the base class Module (which does nothing at all)
 370                 Module::Module() { }
 371                 Module::~Module() { }
 372 void            Module::OnUserConnect(userrec* user) { }
 373 void            Module::OnUserQuit(userrec* user) { }
 374 void            Module::OnUserDisconnect(userrec* user) { }
 375 void            Module::OnUserJoin(userrec* user, chanrec* channel) { }
 376 void            Module::OnUserPart(userrec* user, chanrec* channel) { }
 377 void            Module::OnPacketTransmit(std::string &data, std::string serv) { }
 378 void            Module::OnPacketReceive(std::string &data, std::string serv) { }
 379 void            Module::OnRehash() { }
 380 void            Module::OnServerRaw(std::string &raw, bool inbound, userrec* user) { }
 381 int             Module::OnUserPreJoin(userrec* user, chanrec* chan, const char* cname) { return 0; }
 382 int             Module::OnExtendedMode(userrec* user, void* target, char modechar, int type, bool mode_on, string_list &params) { return false; }
 383 Version         Module::GetVersion() { return Version(1,0,0,0,VF_VENDOR); }
 384 void            Module::OnOper(userrec* user) { };
 385 void            Module::OnInfo(userrec* user) { };
 386 void            Module::OnWhois(userrec* source, userrec* dest) { };
 387 int             Module::OnUserPreInvite(userrec* source,userrec* dest,chanrec* channel) { return 0; };
 388 int             Module::OnUserPreMessage(userrec* user,void* dest,int target_type, std::string &text) { return 0; };
 389 int             Module::OnUserPreNotice(userrec* user,void* dest,int target_type, std::string &text) { return 0; };
 390 int             Module::OnUserPreNick(userrec* user, std::string newnick) { return 0; };
 391 void            Module::OnUserPostNick(userrec* user, std::string oldnick) { };
 392 int             Module::OnAccessCheck(userrec* source,userrec* dest,chanrec* channel,int access_type) { return ACR_DEFAULT; };
 393 string_list     Module::OnUserSync(userrec* user) { string_list empty; return empty; }
 394 string_list     Module::OnChannelSync(chanrec* chan) { string_list empty; return empty; }
 395 void            Module::On005Numeric(std::string &output) { };
 396 int             Module::OnKill(userrec* source, userrec* dest, std::string reason) { return 0; };
 397 void            Module::OnLoadModule(Module* mod,std::string name) { };
 398 void            Module::OnBackgroundTimer(time_t curtime) { };
 399 void            Module::OnSendList(userrec* user, chanrec* channel, char mode) { };
 400 int             Module::OnPreCommand(std::string command, char **parameters, int pcnt, userrec *user) { return 0; };
 401 bool            Module::OnCheckReady(userrec* user) { return true; };
 402 void            Module::OnUserRegister(userrec* user) { };
 403 int             Module::OnUserPreKick(userrec* source, userrec* user, chanrec* chan, std::string reason) { return 0; };
 404 void            Module::OnUserKick(userrec* source, userrec* user, chanrec* chan, std::string reason) { };
 405 int             Module::OnRawMode(userrec* user, chanrec* chan, char mode, std::string param, bool adding, int pcnt) { return 0; };
 406 int             Module::OnCheckInvite(userrec* user, chanrec* chan) { return 0; };
 407 int             Module::OnCheckKey(userrec* user, chanrec* chan, std::string keygiven) { return 0; };
 408 int             Module::OnCheckLimit(userrec* user, chanrec* chan) { return 0; };
 409 int             Module::OnCheckBan(userrec* user, chanrec* chan) { return 0; };
 410 void            Module::OnStats(char symbol) { };
 411 int             Module::OnChangeLocalUserHost(userrec* user, std::string newhost) { return 0; };
 412 int             Module::OnChangeLocalUserGECOS(userrec* user, std::string newhost) { return 0; };
 413 int             Module::OnLocalTopicChange(userrec* user, chanrec* chan, std::string topic) { return 0; };
 414 int             Module::OnMeshToken(char token,string_list params,serverrec* source,serverrec* reply, std::string tcp_host,std::string ipaddr,int port) { return 0; };
 415 void            Module::OnEvent(Event* event) { return; };
 416 char*           Module::OnRequest(Request* request) { return NULL; };
 417 int             Module::OnOperCompare(std::string password, std::string input) { return 0; };
 418 void            Module::OnGlobalOper(userrec* user) { };
 419 void            Module::OnGlobalConnect(userrec* user) { };
 420 int             Module::OnAddBan(userrec* source, chanrec* channel,std::string banmask) { return 0; };
 421 int             Module::OnDelBan(userrec* source, chanrec* channel,std::string banmask) { return 0; };
 422 void            Module::OnRawSocketAccept(int fd, std::string ip, int localport) { };
 423 int             Module::OnRawSocketWrite(int fd, char* buffer, int count) { return 0; };
 424 void            Module::OnRawSocketClose(int fd) { };
 425 int             Module::OnRawSocketRead(int fd, char* buffer, unsigned int count, int &readresult) { return 0; };
 426
 427 // server is a wrapper class that provides methods to all of the C-style
 428 // exports in the core
 429 //
 430
 431 Server::Server()
 432 {
 433 }
 434
 435 Server::~Server()
 436 {
 437 }
 438
 439 void Server::SendOpers(std::string s)
 440 {
 441         WriteOpers("%s",s.c_str());
 442 }
 443
 444 bool Server::MatchText(std::string sliteral, std::string spattern)
 445 {
 446         char literal[MAXBUF],pattern[MAXBUF];
 447         strlcpy(literal,sliteral.c_str(),MAXBUF);
 448         strlcpy(pattern,spattern.c_str(),MAXBUF);
 449         return match(literal,pattern);
 450 }
 451
 452 void Server::SendToModeMask(std::string modes, int flags, std::string text)
 453 {
 454         WriteMode(modes.c_str(),flags,"%s",text.c_str());
 455 }
 456
 457 chanrec* Server::JoinUserToChannel(userrec* user, std::string cname, std::string key)
 458 {
 459         return add_channel(user,cname.c_str(),key.c_str(),false);
 460 }
 461
 462 chanrec* Server::PartUserFromChannel(userrec* user, std::string cname, std::string reason)
 463 {
 464         return del_channel(user,cname.c_str(),reason.c_str(),false);
 465 }
 466
 467 chanuserlist Server::GetUsers(chanrec* chan)
 468 {
 469         chanuserlist userl;
 470         userl.clear();
 471         std::vector<char*> *list = chan->GetUsers();
 472         for (std::vector<char*>::iterator i = list->begin(); i != list->end(); i++)
 473         {
 474                 char* o = *i;
 475                 userl.push_back((userrec*)o);
 476         }
 477         return userl;
 478 }
 479 void Server::ChangeUserNick(userrec* user, std::string nickname)
 480 {
 481         force_nickchange(user,nickname.c_str());
 482 }
 483
 484 void Server::QuitUser(userrec* user, std::string reason)
 485 {
 486         kill_link(user,reason.c_str());
 487 }
 488
 489 bool Server::IsUlined(std::string server)
 490 {
 491         return is_uline(server.c_str());
 492 }
 493
 494 void Server::CallCommandHandler(std::string commandname, char** parameters, int pcnt, userrec* user)
 495 {
 496         call_handler(commandname.c_str(),parameters,pcnt,user);
 497 }
 498
 499 void Server::Log(int level, std::string s)
 500 {
 501         log(level,"%s",s.c_str());
 502 }
 503
 504 void Server::AddCommand(char* cmd, handlerfunc f, char flags, int minparams, char* source)
 505 {
 506         createcommand(cmd,f,flags,minparams,source);
 507 }
 508
 509 void Server::SendMode(char **parameters, int pcnt, userrec *user)
 510 {
 511         server_mode(parameters,pcnt,user);
 512 }
 513
 514 void Server::Send(int Socket, std::string s)
 515 {
 516         Write(Socket,"%s",s.c_str());
 517 }
 518
 519 void Server::SendServ(int Socket, std::string s)
 520 {
 521         WriteServ(Socket,"%s",s.c_str());
 522 }
 523
 524 void Server::SendFrom(int Socket, userrec* User, std::string s)
 525 {
 526         WriteFrom(Socket,User,"%s",s.c_str());
 527 }
 528
 529 void Server::SendTo(userrec* Source, userrec* Dest, std::string s)
 530 {
 531         if (!Source)
 532         {
 533                 // if source is NULL, then the message originates from the local server
 534                 Write(Dest->fd,":%s %s",this->GetServerName().c_str(),s.c_str());
 535         }
 536         else
 537         {
 538                 // otherwise it comes from the user specified
 539                 WriteTo(Source,Dest,"%s",s.c_str());
 540         }
 541 }
 542
 543 void Server::SendChannelServerNotice(std::string ServName, chanrec* Channel, std::string text)
 544 {
 545         WriteChannelWithServ((char*)ServName.c_str(), Channel, "%s", text.c_str());
 546 }
 547
 548 void Server::SendChannel(userrec* User, chanrec* Channel, std::string s,bool IncludeSender)
 549 {
 550         if (IncludeSender)
 551         {
 552                 WriteChannel(Channel,User,"%s",s.c_str());
 553         }
 554         else
 555         {
 556                 ChanExceptSender(Channel,User,"%s",s.c_str());
 557         }
 558 }
 559
 560 bool Server::CommonChannels(userrec* u1, userrec* u2)
 561 {
 562         return (common_channels(u1,u2) != 0);
 563 }
 564
 565 void Server::SendCommon(userrec* User, std::string text,bool IncludeSender)
 566 {
 567         if (IncludeSender)
 568         {
 569                 WriteCommon(User,"%s",text.c_str());
 570         }
 571         else
 572         {
 573                 WriteCommonExcept(User,"%s",text.c_str());
 574         }
 575 }
 576
 577 void Server::SendWallops(userrec* User, std::string text)
 578 {
 579         WriteWallOps(User,false,"%s",text.c_str());
 580 }
 581
 582 void Server::ChangeHost(userrec* user, std::string host)
 583 {
 584         ChangeDisplayedHost(user,host.c_str());
 585 }
 586
 587 void Server::ChangeGECOS(userrec* user, std::string gecos)
 588 {
 589         ChangeName(user,gecos.c_str());
 590 }
 591
 592 bool Server::IsNick(std::string nick)
 593 {
 594         return (isnick(nick.c_str()) != 0);
 595 }
 596
 597 userrec* Server::FindNick(std::string nick)
 598 {
 599         return Find(nick);
 600 }
 601
 602 userrec* Server::FindDescriptor(int socket)
 603 {
 604         return (socket < 65536 ? fd_ref_table[socket] : NULL);
 605 }
 606
 607 chanrec* Server::FindChannel(std::string channel)
 608 {
 609         return FindChan(channel.c_str());
 610 }
 611
 612 std::string Server::ChanMode(userrec* User, chanrec* Chan)
 613 {
 614         return cmode(User,Chan);
 615 }
 616
 617 bool Server::IsOnChannel(userrec* User, chanrec* Chan)
 618 {
 619         return has_channel(User,Chan);
 620 }
 621
 622 std::string Server::GetServerName()
 623 {
 624         return getservername();
 625 }
 626
 627 std::string Server::GetNetworkName()
 628 {
 629         return getnetworkname();
 630 }
 631
 632 std::string Server::GetServerDescription()
 633 {
 634         return getserverdesc();
 635 }
 636
 637 Admin Server::GetAdmin()
 638 {
 639         return Admin(getadminname(),getadminemail(),getadminnick());
 640 }
 641
 642
 643
 644 bool Server::AddExtendedMode(char modechar, int type, bool requires_oper, int params_when_on, int params_when_off)
 645 {
 646         if (((modechar >= 'A') && (modechar <= 'Z')) || ((modechar >= 'a') && (modechar <= 'z')))
 647         {
 648                 if (type == MT_SERVER)
 649                 {
 650                         log(DEBUG,"*** API ERROR *** Modes of type MT_SERVER are reserved for future expansion");
 651                         return false;
 652                 }
 653                 if (((params_when_on>0) || (params_when_off>0)) && (type == MT_CLIENT))
 654                 {
 655                         log(DEBUG,"*** API ERROR *** Parameters on MT_CLIENT modes are not supported");
 656                         return false;
 657                 }
 658                 if ((params_when_on>1) || (params_when_off>1))
 659                 {
 660                         log(DEBUG,"*** API ERROR *** More than one parameter for an MT_CHANNEL mode is not yet supported");
 661                         return false;
 662                 }
 663                 return DoAddExtendedMode(modechar,type,requires_oper,params_when_on,params_when_off);
 664         }
 665         else
 666         {
 667                 log(DEBUG,"*** API ERROR *** Muppet modechar detected.");
 668         }
 669         return false;
 670 }
 671
 672 bool Server::AddExtendedListMode(char modechar)
 673 {
 674         bool res = DoAddExtendedMode(modechar,MT_CHANNEL,false,1,1);
 675         if (res)
 676                 ModeMakeList(modechar);
 677         return res;
 678 }
 679
 680 int Server::CountUsers(chanrec* c)
 681 {
 682         return usercount(c);
 683 }
 684
 685
 686 bool Server::UserToPseudo(userrec* user,std::string message)
 687 {
 688         unsigned int old_fd = user->fd;
 689         user->fd = FD_MAGIC_NUMBER;
 690         user->ClearBuffer();
 691         Write(old_fd,"ERROR :Closing link (%s@%s) [%s]",user->ident,user->host,message.c_str());
 692 #ifdef USE_KQUEUE
 693         struct kevent ke;
 694         EV_SET(&ke, old_fd, EVFILT_READ, EV_DELETE, 0, 0, NULL);
 695         int i = kevent(kq, &ke, 1, 0, 0, NULL);
 696         if (i == -1)
 697         {
 698                 log(DEBUG,"kqueue: Failed to remove user from queue!");
 699         }
 700 #endif
 701         shutdown(old_fd,2);
 702         close(old_fd);
 703 }
 704
 705 bool Server::PseudoToUser(userrec* alive,userrec* zombie,std::string message)
 706 {
 707         zombie->fd = alive->fd;
 708         alive->fd = FD_MAGIC_NUMBER;
 709         alive->ClearBuffer();
 710         Write(zombie->fd,":%s!%s@%s NICK %s",alive->nick,alive->ident,alive->host,zombie->nick);
 711         kill_link(alive,message.c_str());
 712         fd_ref_table[zombie->fd] = zombie;
 713         for (int i = 0; i != MAXCHANS; i++)
 714         {
 715                 if (zombie->chans[i].channel != NULL)
 716                 {
 717                         if (zombie->chans[i].channel->name)
 718                         {
 719                                 chanrec* Ptr = zombie->chans[i].channel;
 720                                 WriteFrom(zombie->fd,zombie,"JOIN %s",Ptr->name);
 721                                 if (Ptr->topicset)
 722                                 {
 723                                         WriteServ(zombie->fd,"332 %s %s :%s", zombie->nick, Ptr->name, Ptr->topic);
 724                                         WriteServ(zombie->fd,"333 %s %s %s %d", zombie->nick, Ptr->name, Ptr->setby, Ptr->topicset);
 725                                 }
 726                                 userlist(zombie,Ptr);
 727                                 WriteServ(zombie->fd,"366 %s %s :End of /NAMES list.", zombie->nick, Ptr->name);
 728
 729                         }
 730                 }
 731         }
 732
 733 }
 734
 735 void Server::AddGLine(long duration, std::string source, std::string reason, std::string hostmask)
 736 {
 737         add_gline(duration, source.c_str(), reason.c_str(), hostmask.c_str());
 738 }
 739
 740 void Server::AddQLine(long duration, std::string source, std::string reason, std::string nickname)
 741 {
 742         add_qline(duration, source.c_str(), reason.c_str(), nickname.c_str());
 743 }
 744
 745 void Server::AddZLine(long duration, std::string source, std::string reason, std::string ipaddr)
 746 {
 747         add_zline(duration, source.c_str(), reason.c_str(), ipaddr.c_str());
 748 }
 749
 750 void Server::AddKLine(long duration, std::string source, std::string reason, std::string hostmask)
 751 {
 752         add_kline(duration, source.c_str(), reason.c_str(), hostmask.c_str());
 753 }
 754
 755 void Server::AddELine(long duration, std::string source, std::string reason, std::string hostmask)
 756 {
 757         add_eline(duration, source.c_str(), reason.c_str(), hostmask.c_str());
 758 }
 759
 760 bool Server::DelGLine(std::string hostmask)
 761 {
 762         del_gline(hostmask.c_str());
 763 }
 764
 765 bool Server::DelQLine(std::string nickname)
 766 {
 767         del_qline(nickname.c_str());
 768 }
 769
 770 bool Server::DelZLine(std::string ipaddr)
 771 {
 772         del_zline(ipaddr.c_str());
 773 }
 774
 775 bool Server::DelKLine(std::string hostmask)
 776 {
 777         del_kline(hostmask.c_str());
 778 }
 779
 780 bool Server::DelELine(std::string hostmask)
 781 {
 782         del_eline(hostmask.c_str());
 783 }
 784
 785 long Server::CalcDuration(std::string delta)
 786 {
 787         return duration(delta.c_str());
 788 }
 789
 790 bool Server::IsValidMask(std::string mask)
 791 {
 792         const char* dest = mask.c_str();
 793         if (strchr(dest,'!')==0)
 794                 return false;
 795         if (strchr(dest,'@')==0)
 796                 return false;
 797         for (int i = 0; i < strlen(dest); i++)
 798                 if (dest[i] < 32)
 799                         return false;
 800         for (int i = 0; i < strlen(dest); i++)
 801                 if (dest[i] > 126)
 802                         return false;
 803         int c = 0;
 804         for (int i = 0; i < strlen(dest); i++)
 805                 if (dest[i] == '!')
 806                         c++;
 807         if (c>1)
 808                 return false;
 809         c = 0;
 810         for (int i = 0; i < strlen(dest); i++)
 811                 if (dest[i] == '@')
 812                         c++;
 813         if (c>1)
 814                 return false;
 815
 816         return true;
 817 }
 818
 819 void Server::MeshSendAll(std::string text)
 820 {
 821         NetSendToAll((char*)text.c_str());
 822 }
 823
 824 void Server::MeshSendCommon(userrec* user, std::string text)
 825 {
 826         if (user)
 827                 NetSendToCommon(user,(char*)text.c_str());
 828 }
 829
 830 void Server::MeshSendAllAlive(std::string text)
 831 {
 832         NetSendToAllAlive((char*)text.c_str());
 833 }
 834
 835 void Server::MeshSendUnicast(std::string destination, std::string text)
 836 {
 837         NetSendToOne((char*)destination.c_str(),(char*)text.c_str());
 838 }
 839
 840 void Server::MeshSendAllExcept(std::string target, std::string text)
 841 {
 842         NetSendToAllExcept(target.c_str(),(char*)text.c_str());
 843 }
 844
 845 bool Server::MeshCheckChan(chanrec *c,std::string servername)
 846 {
 847         if (c)
 848         {
 849                 return ChanAnyOnThisServer(c,(char*)servername.c_str());
 850         }
 851         else return false;
 852 }
 853
 854 bool Server::MeshCheckCommon(userrec* u,std::string servername)
 855 {
 856         if (u)
 857         {
 858                 return CommonOnThisServer(u,(char*)servername.c_str());
 859         }
 860         else return false;
 861 }
 862
 863 Module* Server::FindModule(std::string name)
 864 {
 865         for (int i = 0; i <= MODCOUNT; i++)
 866         {
 867                 if (module_names[i] == name)
 868                 {
 869                         return modules[i];
 870                 }
 871         }
 872         return NULL;
 873 }
 874
 875 ConfigReader::ConfigReader()
 876 {
 877         this->cache = new std::stringstream(std::stringstream::in | std::stringstream::out);
 878         this->errorlog = new std::stringstream(std::stringstream::in | std::stringstream::out);
 879         this->readerror = LoadConf(CONFIG_FILE,this->cache,this->errorlog);
 880         if (!this->readerror)
 881                 this->error = CONF_FILE_NOT_FOUND;
 882 }
 883
 884
 885 ConfigReader::~ConfigReader()
 886 {
 887         if (this->cache)
 888                 delete this->cache;
 889         if (this->errorlog)
 890                 delete this->errorlog;
 891 }
 892
 893
 894 ConfigReader::ConfigReader(std::string filename)
 895 {
 896         this->cache = new std::stringstream(std::stringstream::in | std::stringstream::out);
 897         this->errorlog = new std::stringstream(std::stringstream::in | std::stringstream::out);
 898         this->readerror = LoadConf(filename.c_str(),this->cache,this->errorlog);
 899         if (!this->readerror)
 900                 this->error = CONF_FILE_NOT_FOUND;
 901 };
 902
 903 std::string ConfigReader::ReadValue(std::string tag, std::string name, int index)
 904 {
 905         char val[MAXBUF];
 906         char t[MAXBUF];
 907         char n[MAXBUF];
 908         strlcpy(t,tag.c_str(),MAXBUF);
 909         strlcpy(n,name.c_str(),MAXBUF);
 910         int res = ReadConf(cache,t,n,index,val);
 911         if (!res)
 912         {
 913                 this->error = CONF_VALUE_NOT_FOUND;
 914                 return "";
 915         }
 916         return val;
 917 }
 918
 919 bool ConfigReader::ReadFlag(std::string tag, std::string name, int index)
 920 {
 921         char val[MAXBUF];
 922         char t[MAXBUF];
 923         char n[MAXBUF];
 924         strlcpy(t,tag.c_str(),MAXBUF);
 925         strlcpy(n,name.c_str(),MAXBUF);
 926         int res = ReadConf(cache,t,n,index,val);
 927         if (!res)
 928         {
 929                 this->error = CONF_VALUE_NOT_FOUND;
 930                 return false;
 931         }
 932         std::string s = val;
 933         return ((s == "yes") || (s == "YES") || (s == "true") || (s == "TRUE") || (s == "1"));
 934 }
 935
 936 long ConfigReader::ReadInteger(std::string tag, std::string name, int index, bool needs_unsigned)
 937 {
 938         char val[MAXBUF];
 939         char t[MAXBUF];
 940         char n[MAXBUF];
 941         strlcpy(t,tag.c_str(),MAXBUF);
 942         strlcpy(n,name.c_str(),MAXBUF);
 943         int res = ReadConf(cache,t,n,index,val);
 944         if (!res)
 945         {
 946                 this->error = CONF_VALUE_NOT_FOUND;
 947                 return 0;
 948         }
 949         for (int i = 0; i < strlen(val); i++)
 950         {
 951                 if (!isdigit(val[i]))
 952                 {
 953                         this->error = CONF_NOT_A_NUMBER;
 954                         return 0;
 955                 }
 956         }
 957         if ((needs_unsigned) && (atoi(val)<0))
 958         {
 959                 this->error = CONF_NOT_UNSIGNED;
 960                 return 0;
 961         }
 962         return atoi(val);
 963 }
 964
 965 long ConfigReader::GetError()
 966 {
 967         long olderr = this->error;
 968         this->error = 0;
 969         return olderr;
 970 }
 971
 972 void ConfigReader::DumpErrors(bool bail, userrec* user)
 973 {
 974         if (bail)
 975         {
 976                 printf("There were errors in your configuration:\n%s",errorlog->str().c_str());
 977                 exit(0);
 978         }
 979         else
 980         {
 981                 char dataline[1024];
 982                 if (user)
 983                 {
 984                         WriteServ(user->fd,"NOTICE %s :There were errors in the configuration file:",user->nick);
 985                         while (!errorlog->eof())
 986                         {
 987                                 errorlog->getline(dataline,1024);
 988                                 WriteServ(user->fd,"NOTICE %s :%s",user->nick,dataline);
 989                         }
 990                 }
 991                 else
 992                 {
 993                         WriteOpers("There were errors in the configuration file:",user->nick);
 994                         while (!errorlog->eof())
 995                         {
 996                                 errorlog->getline(dataline,1024);
 997                                 WriteOpers(dataline);
 998                         }
 999                 }
1000                 return;
1001         }
1002 }
1003
1004
1005 int ConfigReader::Enumerate(std::string tag)
1006 {
1007         return EnumConf(cache,tag.c_str());
1008 }
1009
1010 int ConfigReader::EnumerateValues(std::string tag, int index)
1011 {
1012         return EnumValues(cache, tag.c_str(), index);
1013 }
1014
1015 bool ConfigReader::Verify()
1016 {
1017         return this->readerror;
1018 }
1019
1020
1021 FileReader::FileReader(std::string filename)
1022 {
1023         file_cache c;
1024         readfile(c,filename.c_str());
1025         this->fc = c;
1026 }
1027
1028 FileReader::FileReader()
1029 {
1030 }
1031
1032 void FileReader::LoadFile(std::string filename)
1033 {
1034         file_cache c;
1035         readfile(c,filename.c_str());
1036         this->fc = c;
1037 }
1038
1039
1040 FileReader::~FileReader()
1041 {
1042 }
1043
1044 bool FileReader::Exists()
1045 {
1046         if (fc.size() == 0)
1047         {
1048                 return(false);
1049         }
1050         else
1051         {
1052                 return(true);
1053         }
1054 }
1055
1056 std::string FileReader::GetLine(int x)
1057 {
1058         if ((x<0) || (x>fc.size()))
1059                 return "";
1060         return fc[x];
1061 }
1062
1063 int FileReader::FileSize()
1064 {
1065         return fc.size();
1066 }
1067
1068
1069 std::vector<Module*> modules(255);
1070 std::vector<ircd_module*> factory(255);
1071
1072 int MODCOUNT  = -1;
1073
1074