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