X-Git-Url: https://git.netwichtig.de/gitweb/?a=blobdiff_plain;f=src%2Fmodules.cpp;h=35372a71edd45e11ff61beb3b9831d1925e5a518;hb=878e437589ee448bc2e87200890cbd446accfc68;hp=02221f1a63c7a3d1655f12c908ac2856a30b4817;hpb=580632d29ae6421afe7b2d4bd97323ace3bbdced;p=user%2Fhenk%2Fcode%2Finspircd.git diff --git a/src/modules.cpp b/src/modules.cpp index 02221f1a6..35372a71e 100644 --- a/src/modules.cpp +++ b/src/modules.cpp @@ -14,16 +14,25 @@ * --------------------------------------------------- */ +using namespace std; + +#include "inspircd_config.h" #include "inspircd.h" #include "inspircd_io.h" #include "inspircd_util.h" -#include "inspircd_config.h" #include -#include #include -#include -#include -#include + +#ifdef USE_KQUEUE +#include +#include +#include +#endif + +#ifdef USE_EPOLL +#include +#endif + #include #include #ifdef GCC3 @@ -34,11 +43,7 @@ #include #include #include -#include #include -#include -#include -#include #include "connection.h" #include "users.h" #include "servers.h" @@ -52,19 +57,23 @@ #include "xline.h" #include "commands.h" #include "inspstring.h" +#include "helperfuncs.h" +#include "hashcomp.h" -#ifdef GCC3 -#define nspace __gnu_cxx -#else -#define nspace std +#ifdef USE_KQUEUE +extern int kq; #endif -using namespace std; +#ifdef USE_EPOLL +int ep; +#endif extern int MODCOUNT; extern std::vector modules; extern std::vector factory; +extern std::vector include_stack; + extern time_t TIME; extern int LogLevel; @@ -91,12 +100,11 @@ extern int NetBufferSize; extern int MaxWhoResults; extern time_t nb_start; -extern std::vector fd_reap; extern std::vector module_names; extern int boundPortCount; extern int portCount; -extern int UDPportCount; +extern int SERVERportCount; extern int ports[MAXSOCKS]; extern int defaultRoute; @@ -107,78 +115,18 @@ extern serverrec* me[32]; extern FILE *log_file; +extern userrec* fd_ref_table[65536]; -namespace nspace -{ -#ifdef GCC34 - template<> struct hash -#else - template<> struct nspace::hash -#endif - { - size_t operator()(const struct in_addr &a) const - { - size_t q; - memcpy(&q,&a,sizeof(size_t)); - return q; - } - }; -#ifdef GCC34 - template<> struct hash -#else - template<> struct nspace::hash -#endif - { - size_t operator()(const string &s) const - { - char a[MAXBUF]; - static struct hash strhash; - strlcpy(a,s.c_str(),MAXBUF); - strlower(a); - return strhash(a); - } - }; -} - -struct StrHashComp -{ - - bool operator()(const string& s1, const string& s2) const - { - char a[MAXBUF],b[MAXBUF]; - strlcpy(a,s1.c_str(),MAXBUF); - strlcpy(b,s2.c_str(),MAXBUF); - return (strcasecmp(a,b) == 0); - } - -}; - -struct InAddr_HashComp -{ - - bool operator()(const in_addr &s1, const in_addr &s2) const - { - size_t q; - size_t p; - - memcpy(&q,&s1,sizeof(size_t)); - memcpy(&p,&s2,sizeof(size_t)); - - return (q == p); - } - -}; - - -typedef nspace::hash_map, StrHashComp> user_hash; -typedef nspace::hash_map, StrHashComp> chan_hash; -typedef nspace::hash_map, InAddr_HashComp> address_cache; +typedef nspace::hash_map, irc::StrHashComp> user_hash; +typedef nspace::hash_map, irc::StrHashComp> chan_hash; +typedef nspace::hash_map, irc::InAddr_HashComp> address_cache; +typedef nspace::hash_map, irc::StrHashComp> whowas_hash; typedef std::deque command_table; extern user_hash clientlist; extern chan_hash chanlist; -extern user_hash whowas; +extern whowas_hash whowas; extern command_table cmdlist; extern file_cache MOTD; extern file_cache RULES; @@ -192,9 +140,9 @@ class ExtMode : public classbase public: char modechar; int type; + bool needsoper; int params_when_on; int params_when_off; - bool needsoper; bool list; 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) { }; }; @@ -208,7 +156,6 @@ ExtModeList EMode; // returns true if an extended mode character is in use bool ModeDefined(char modechar, int type) { - log(DEBUG,"Size of extmodes vector is %d",EMode.size()); for (ExtModeListIter i = EMode.begin(); i < EMode.end(); i++) { if ((i->modechar == modechar) && (i->type == type)) @@ -221,7 +168,6 @@ bool ModeDefined(char modechar, int type) bool ModeIsListMode(char modechar, int type) { - log(DEBUG,"Size of extmodes vector is %d",EMode.size()); for (ExtModeListIter i = EMode.begin(); i < EMode.end(); i++) { if ((i->modechar == modechar) && (i->type == type) && (i->list == true)) @@ -234,7 +180,6 @@ bool ModeIsListMode(char modechar, int type) bool ModeDefinedOper(char modechar, int type) { - log(DEBUG,"Size of extmodes vector is %d",EMode.size()); for (ExtModeListIter i = EMode.begin(); i < EMode.end(); i++) { if ((i->modechar == modechar) && (i->type == type) && (i->needsoper == true)) @@ -303,40 +248,117 @@ Version::Version(int major, int minor, int revision, int build, int flags) : Maj Admin::Admin(std::string name, std::string email, std::string nick) : Name(name), Email(email), Nick(nick) { }; -Module::Module() { } -Module::~Module() { } -void Module::OnUserConnect(userrec* user) { } -void Module::OnUserQuit(userrec* user) { } -void Module::OnUserJoin(userrec* user, chanrec* channel) { } -void Module::OnUserPart(userrec* user, chanrec* channel) { } -void Module::OnPacketTransmit(std::string &data, std::string serv) { } -void Module::OnPacketReceive(std::string &data, std::string serv) { } -void Module::OnRehash() { } -void Module::OnServerRaw(std::string &raw, bool inbound, userrec* user) { } -int Module::OnUserPreJoin(userrec* user, chanrec* chan, const char* cname) { return 0; } -int Module::OnExtendedMode(userrec* user, void* target, char modechar, int type, bool mode_on, string_list ¶ms) { return false; } -Version Module::GetVersion() { return Version(1,0,0,0,VF_VENDOR); } -void Module::OnOper(userrec* user) { }; -void Module::OnInfo(userrec* user) { }; -void Module::OnWhois(userrec* source, userrec* dest) { }; -int Module::OnUserPreInvite(userrec* source,userrec* dest,chanrec* channel) { return 0; }; -int Module::OnUserPreMessage(userrec* user,void* dest,int target_type, std::string &text) { return 0; }; -int Module::OnUserPreNotice(userrec* user,void* dest,int target_type, std::string &text) { return 0; }; -int Module::OnUserPreNick(userrec* user, std::string newnick) { return 0; }; -void Module::OnUserPostNick(userrec* user, std::string oldnick) { }; -int Module::OnAccessCheck(userrec* source,userrec* dest,chanrec* channel,int access_type) { return ACR_DEFAULT; }; -string_list Module::OnUserSync(userrec* user) { string_list empty; return empty; } -string_list Module::OnChannelSync(chanrec* chan) { string_list empty; return empty; } -void Module::On005Numeric(std::string &output) { }; -int Module::OnKill(userrec* source, userrec* dest, std::string reason) { return 0; }; -void Module::OnLoadModule(Module* mod,std::string name) { }; -void Module::OnBackgroundTimer(time_t curtime) { }; -void Module::OnSendList(userrec* user, chanrec* channel, char mode) { }; -int Module::OnPreCommand(std::string command, char **parameters, int pcnt, userrec *user) { return 0; }; -bool Module::OnCheckReady(userrec* user) { return true; }; -void Module::OnUserRegister(userrec* user) { }; -int Module::OnUserPreKick(userrec* source, userrec* user, chanrec* chan, std::string reason) { return 0; }; -void Module::OnUserKick(userrec* source, userrec* user, chanrec* chan, std::string reason) { }; +Request::Request(char* anydata, Module* src, Module* dst) : data(anydata), source(src), dest(dst) { }; + +char* Request::GetData() +{ + return this->data; +} + +Module* Request::GetSource() +{ + return this->source; +} + +Module* Request::GetDest() +{ + return this->dest; +} + +char* Request::Send() +{ + if (this->dest) + { + return dest->OnRequest(this); + } + else + { + return NULL; + } +} + +Event::Event(char* anydata, Module* src, std::string eventid) : data(anydata), source(src), id(eventid) { }; + +char* Event::GetData() +{ + return this->data; +} + +Module* Event::GetSource() +{ + return this->source; +} + +char* Event::Send() +{ + FOREACH_MOD OnEvent(this); + return NULL; +} + +std::string Event::GetEventID() +{ + return this->id; +} + + +// These declarations define the behavours of the base class Module (which does nothing at all) + Module::Module() { } + Module::~Module() { } +void Module::OnUserConnect(userrec* user) { } +void Module::OnUserQuit(userrec* user) { } +void Module::OnUserDisconnect(userrec* user) { } +void Module::OnUserJoin(userrec* user, chanrec* channel) { } +void Module::OnUserPart(userrec* user, chanrec* channel) { } +void Module::OnPacketTransmit(std::string &data, std::string serv) { } +void Module::OnPacketReceive(std::string &data, std::string serv) { } +void Module::OnRehash() { } +void Module::OnServerRaw(std::string &raw, bool inbound, userrec* user) { } +int Module::OnUserPreJoin(userrec* user, chanrec* chan, const char* cname) { return 0; } +int Module::OnExtendedMode(userrec* user, void* target, char modechar, int type, bool mode_on, string_list ¶ms) { return false; } +Version Module::GetVersion() { return Version(1,0,0,0,VF_VENDOR); } +void Module::OnOper(userrec* user) { }; +void Module::OnInfo(userrec* user) { }; +void Module::OnWhois(userrec* source, userrec* dest) { }; +int Module::OnUserPreInvite(userrec* source,userrec* dest,chanrec* channel) { return 0; }; +int Module::OnUserPreMessage(userrec* user,void* dest,int target_type, std::string &text) { return 0; }; +int Module::OnUserPreNotice(userrec* user,void* dest,int target_type, std::string &text) { return 0; }; +int Module::OnUserPreNick(userrec* user, std::string newnick) { return 0; }; +void Module::OnUserPostNick(userrec* user, std::string oldnick) { }; +int Module::OnAccessCheck(userrec* source,userrec* dest,chanrec* channel,int access_type) { return ACR_DEFAULT; }; +string_list Module::OnUserSync(userrec* user) { string_list empty; return empty; } +string_list Module::OnChannelSync(chanrec* chan) { string_list empty; return empty; } +void Module::On005Numeric(std::string &output) { }; +int Module::OnKill(userrec* source, userrec* dest, std::string reason) { return 0; }; +void Module::OnLoadModule(Module* mod,std::string name) { }; +void Module::OnUnloadModule(Module* mod,std::string name) { }; +void Module::OnBackgroundTimer(time_t curtime) { }; +void Module::OnSendList(userrec* user, chanrec* channel, char mode) { }; +int Module::OnPreCommand(std::string command, char **parameters, int pcnt, userrec *user) { return 0; }; +bool Module::OnCheckReady(userrec* user) { return true; }; +void Module::OnUserRegister(userrec* user) { }; +int Module::OnUserPreKick(userrec* source, userrec* user, chanrec* chan, std::string reason) { return 0; }; +void Module::OnUserKick(userrec* source, userrec* user, chanrec* chan, std::string reason) { }; +int Module::OnRawMode(userrec* user, chanrec* chan, char mode, std::string param, bool adding, int pcnt) { return 0; }; +int Module::OnCheckInvite(userrec* user, chanrec* chan) { return 0; }; +int Module::OnCheckKey(userrec* user, chanrec* chan, std::string keygiven) { return 0; }; +int Module::OnCheckLimit(userrec* user, chanrec* chan) { return 0; }; +int Module::OnCheckBan(userrec* user, chanrec* chan) { return 0; }; +void Module::OnStats(char symbol) { }; +int Module::OnChangeLocalUserHost(userrec* user, std::string newhost) { return 0; }; +int Module::OnChangeLocalUserGECOS(userrec* user, std::string newhost) { return 0; }; +int Module::OnLocalTopicChange(userrec* user, chanrec* chan, std::string topic) { return 0; }; +int Module::OnMeshToken(char token,string_list params,serverrec* source,serverrec* reply, std::string tcp_host,std::string ipaddr,int port) { return 0; }; +void Module::OnEvent(Event* event) { return; }; +char* Module::OnRequest(Request* request) { return NULL; }; +int Module::OnOperCompare(std::string password, std::string input) { return 0; }; +void Module::OnGlobalOper(userrec* user) { }; +void Module::OnGlobalConnect(userrec* user) { }; +int Module::OnAddBan(userrec* source, chanrec* channel,std::string banmask) { return 0; }; +int Module::OnDelBan(userrec* source, chanrec* channel,std::string banmask) { return 0; }; +void Module::OnRawSocketAccept(int fd, std::string ip, int localport) { }; +int Module::OnRawSocketWrite(int fd, char* buffer, int count) { return 0; }; +void Module::OnRawSocketClose(int fd) { }; +int Module::OnRawSocketRead(int fd, char* buffer, unsigned int count, int &readresult) { return 0; }; // server is a wrapper class that provides methods to all of the C-style // exports in the core @@ -370,7 +392,7 @@ void Server::SendToModeMask(std::string modes, int flags, std::string text) chanrec* Server::JoinUserToChannel(userrec* user, std::string cname, std::string key) { - return add_channel(user,cname.c_str(),key.c_str(),true); + return add_channel(user,cname.c_str(),key.c_str(),false); } chanrec* Server::PartUserFromChannel(userrec* user, std::string cname, std::string reason) @@ -382,18 +404,11 @@ chanuserlist Server::GetUsers(chanrec* chan) { chanuserlist userl; userl.clear(); - for (user_hash::const_iterator i = clientlist.begin(); i != clientlist.end(); i++) + std::vector *list = chan->GetUsers(); + for (std::vector::iterator i = list->begin(); i != list->end(); i++) { - if (i->second) - { - if (has_channel(i->second,chan)) - { - if (isnick(i->second->nick)) - { - userl.push_back(i->second); - } - } - } + char* o = *i; + userl.push_back((userrec*)o); } return userl; } @@ -404,7 +419,6 @@ void Server::ChangeUserNick(userrec* user, std::string nickname) void Server::QuitUser(userrec* user, std::string reason) { - send_network_quit(user->nick,reason.c_str()); kill_link(user,reason.c_str()); } @@ -462,6 +476,11 @@ void Server::SendTo(userrec* Source, userrec* Dest, std::string s) } } +void Server::SendChannelServerNotice(std::string ServName, chanrec* Channel, std::string text) +{ + WriteChannelWithServ((char*)ServName.c_str(), Channel, "%s", text.c_str()); +} + void Server::SendChannel(userrec* User, chanrec* Channel, std::string s,bool IncludeSender) { if (IncludeSender) @@ -516,6 +535,11 @@ userrec* Server::FindNick(std::string nick) return Find(nick); } +userrec* Server::FindDescriptor(int socket) +{ + return (socket < 65536 ? fd_ref_table[socket] : NULL); +} + chanrec* Server::FindChannel(std::string channel) { return FindChan(channel.c_str()); @@ -541,6 +565,11 @@ std::string Server::GetNetworkName() return getnetworkname(); } +std::string Server::GetServerDescription() +{ + return getserverdesc(); +} + Admin Server::GetAdmin() { return Admin(getadminname(),getadminemail(),getadminnick()); @@ -550,22 +579,30 @@ Admin Server::GetAdmin() bool Server::AddExtendedMode(char modechar, int type, bool requires_oper, int params_when_on, int params_when_off) { - if (type == MT_SERVER) - { - log(DEBUG,"*** API ERROR *** Modes of type MT_SERVER are reserved for future expansion"); - return false; - } - if (((params_when_on>0) || (params_when_off>0)) && (type == MT_CLIENT)) + if (((modechar >= 'A') && (modechar <= 'Z')) || ((modechar >= 'a') && (modechar <= 'z'))) { - log(DEBUG,"*** API ERROR *** Parameters on MT_CLIENT modes are not supported"); - return false; + if (type == MT_SERVER) + { + log(DEBUG,"*** API ERROR *** Modes of type MT_SERVER are reserved for future expansion"); + return false; + } + if (((params_when_on>0) || (params_when_off>0)) && (type == MT_CLIENT)) + { + log(DEBUG,"*** API ERROR *** Parameters on MT_CLIENT modes are not supported"); + return false; + } + if ((params_when_on>1) || (params_when_off>1)) + { + log(DEBUG,"*** API ERROR *** More than one parameter for an MT_CHANNEL mode is not yet supported"); + return false; + } + return DoAddExtendedMode(modechar,type,requires_oper,params_when_on,params_when_off); } - if ((params_when_on>1) || (params_when_off>1)) + else { - log(DEBUG,"*** API ERROR *** More than one parameter for an MT_CHANNEL mode is not yet supported"); - return false; + log(DEBUG,"*** API ERROR *** Muppet modechar detected."); } - return DoAddExtendedMode(modechar,type,requires_oper,params_when_on,params_when_off); + return false; } bool Server::AddExtendedListMode(char modechar) @@ -586,17 +623,41 @@ bool Server::UserToPseudo(userrec* user,std::string message) { unsigned int old_fd = user->fd; user->fd = FD_MAGIC_NUMBER; + user->ClearBuffer(); Write(old_fd,"ERROR :Closing link (%s@%s) [%s]",user->ident,user->host,message.c_str()); - close(old_fd); - shutdown (old_fd,2); +#ifdef USE_KQUEUE + struct kevent ke; + EV_SET(&ke, old_fd, EVFILT_READ, EV_DELETE, 0, 0, NULL); + int i = kevent(kq, &ke, 1, 0, 0, NULL); + if (i == -1) + { + log(DEBUG,"kqueue: Failed to remove user from queue!"); + } +#endif +#ifdef USE_EPOLL + struct epoll_event ev; + ev.events = EPOLLIN | EPOLLET; + ev.data.fd = old_fd; + int i = epoll_ctl(ep, EPOLL_CTL_DEL, old_fd, &ev); + if (i < 0) + { + log(DEBUG,"epoll: List deletion failure!"); + } +#endif + + shutdown(old_fd,2); + close(old_fd); + return true; } bool Server::PseudoToUser(userrec* alive,userrec* zombie,std::string message) { zombie->fd = alive->fd; alive->fd = FD_MAGIC_NUMBER; + alive->ClearBuffer(); Write(zombie->fd,":%s!%s@%s NICK %s",alive->nick,alive->ident,alive->host,zombie->nick); kill_link(alive,message.c_str()); + fd_ref_table[zombie->fd] = zombie; for (int i = 0; i != MAXCHANS; i++) { if (zombie->chans[i].channel != NULL) @@ -612,13 +673,11 @@ bool Server::PseudoToUser(userrec* alive,userrec* zombie,std::string message) } userlist(zombie,Ptr); WriteServ(zombie->fd,"366 %s %s :End of /NAMES list.", zombie->nick, Ptr->name); - WriteServ(zombie->fd,"324 %s %s +%s",zombie->nick, Ptr->name,chanmodes(Ptr)); - WriteServ(zombie->fd,"329 %s %s %d", zombie->nick, Ptr->name, Ptr->created); } } } - + return true; } void Server::AddGLine(long duration, std::string source, std::string reason, std::string hostmask) @@ -648,27 +707,27 @@ void Server::AddELine(long duration, std::string source, std::string reason, std bool Server::DelGLine(std::string hostmask) { - del_gline(hostmask.c_str()); + return del_gline(hostmask.c_str()); } bool Server::DelQLine(std::string nickname) { - del_qline(nickname.c_str()); + return del_qline(nickname.c_str()); } bool Server::DelZLine(std::string ipaddr) { - del_zline(ipaddr.c_str()); + return del_zline(ipaddr.c_str()); } bool Server::DelKLine(std::string hostmask) { - del_kline(hostmask.c_str()); + return del_kline(hostmask.c_str()); } bool Server::DelELine(std::string hostmask) { - del_eline(hostmask.c_str()); + return del_eline(hostmask.c_str()); } long Server::CalcDuration(std::string delta) @@ -683,20 +742,20 @@ bool Server::IsValidMask(std::string mask) return false; if (strchr(dest,'@')==0) return false; - for (int i = 0; i < strlen(dest); i++) + for (unsigned int i = 0; i < strlen(dest); i++) if (dest[i] < 32) return false; - for (int i = 0; i < strlen(dest); i++) + for (unsigned int i = 0; i < strlen(dest); i++) if (dest[i] > 126) return false; - int c = 0; - for (int i = 0; i < strlen(dest); i++) + unsigned int c = 0; + for (unsigned int i = 0; i < strlen(dest); i++) if (dest[i] == '!') c++; if (c>1) return false; c = 0; - for (int i = 0; i < strlen(dest); i++) + for (unsigned int i = 0; i < strlen(dest); i++) if (dest[i] == '@') c++; if (c>1) @@ -705,8 +764,65 @@ bool Server::IsValidMask(std::string mask) return true; } +void Server::MeshSendAll(std::string text) +{ + NetSendToAll((char*)text.c_str()); +} + +void Server::MeshSendCommon(userrec* user, std::string text) +{ + if (user) + NetSendToCommon(user,(char*)text.c_str()); +} + +void Server::MeshSendAllAlive(std::string text) +{ + NetSendToAllAlive((char*)text.c_str()); +} + +void Server::MeshSendUnicast(std::string destination, std::string text) +{ + NetSendToOne((char*)destination.c_str(),(char*)text.c_str()); +} + +void Server::MeshSendAllExcept(std::string target, std::string text) +{ + NetSendToAllExcept(target.c_str(),(char*)text.c_str()); +} + +bool Server::MeshCheckChan(chanrec *c,std::string servername) +{ + if (c) + { + return ChanAnyOnThisServer(c,(char*)servername.c_str()); + } + else return false; +} + +bool Server::MeshCheckCommon(userrec* u,std::string servername) +{ + if (u) + { + return CommonOnThisServer(u,(char*)servername.c_str()); + } + else return false; +} + +Module* Server::FindModule(std::string name) +{ + for (int i = 0; i <= MODCOUNT; i++) + { + if (module_names[i] == name) + { + return modules[i]; + } + } + return NULL; +} + ConfigReader::ConfigReader() { + include_stack.clear(); this->cache = new std::stringstream(std::stringstream::in | std::stringstream::out); this->errorlog = new std::stringstream(std::stringstream::in | std::stringstream::out); this->readerror = LoadConf(CONFIG_FILE,this->cache,this->errorlog); @@ -746,7 +862,7 @@ std::string ConfigReader::ReadValue(std::string tag, std::string name, int index this->error = CONF_VALUE_NOT_FOUND; return ""; } - return std::string(val); + return val; } bool ConfigReader::ReadFlag(std::string tag, std::string name, int index) @@ -779,7 +895,7 @@ long ConfigReader::ReadInteger(std::string tag, std::string name, int index, boo this->error = CONF_VALUE_NOT_FOUND; return 0; } - for (int i = 0; i < strlen(val); i++) + for (unsigned int i = 0; i < strlen(val); i++) { if (!isdigit(val[i])) { @@ -888,7 +1004,7 @@ bool FileReader::Exists() std::string FileReader::GetLine(int x) { - if ((x<0) || (x>fc.size())) + if ((x<0) || ((unsigned)x>fc.size())) return ""; return fc[x]; }