]> git.netwichtig.de Git - user/henk/code/inspircd.git/blobdiff - src/inspircd.cpp
Added m_watch.cpp (provides /WATCH for notify) and fixes to allow it to work
[user/henk/code/inspircd.git] / src / inspircd.cpp
index f11070d0726c413689bf0445c960d7275c5ef147..c780b8bf1c33c21cf9ca653ae9ac3aeaec32dc4f 100644 (file)
 
 using namespace std;
 
+#include "inspircd_config.h"
 #include "inspircd.h"
 #include "inspircd_io.h"
 #include "inspircd_util.h"
-#include "inspircd_config.h"
 #include <unistd.h>
 #include <fcntl.h>
 #include <sys/errno.h>
@@ -119,12 +119,16 @@ int kq, lkq, skq;
 int ep, lep, sep;
 #endif
 
+bool has_been_netsplit = false;
+extern std::vector<std::string> include_stack;
+
 typedef nspace::hash_map<std::string, userrec*, nspace::hash<string>, irc::StrHashComp> user_hash;
 typedef nspace::hash_map<std::string, chanrec*, nspace::hash<string>, irc::StrHashComp> chan_hash;
 typedef nspace::hash_map<in_addr,string*, nspace::hash<in_addr>, irc::InAddr_HashComp> address_cache;
 typedef nspace::hash_map<std::string, WhoWasUser*, nspace::hash<string>, irc::StrHashComp> whowas_hash;
 typedef std::deque<command_t> command_table;
 typedef std::map<std::string,time_t> autoconnects;
+typedef std::vector<std::string> servernamelist;
 
 // This table references users by file descriptor.
 // its an array to make it VERY fast, as all lookups are referenced
@@ -147,6 +151,7 @@ file_cache RULES;
 address_cache IP;
 
 ClassVector Classes;
+servernamelist servernames;
 
 struct linger linger = { 0 };
 char MyExecutable[1024];
@@ -177,6 +182,26 @@ void AddOper(userrec* user)
        all_opers.push_back(user);
 }
 
+void AddServerName(std::string servername)
+{
+       for (servernamelist::iterator a = servernames.begin(); a < servernames.end(); a++)
+       {
+               if (*a == servername)
+                       return;
+       }
+       servernames.push_back(servername);
+}
+
+const char* FindServerNamePtr(std::string servername)
+{
+       for (servernamelist::iterator a = servernames.begin(); a < servernames.end(); a++)
+       {
+               if (*a == servername)
+                       return a->c_str();
+       }
+       return "";
+}
+
 void DeleteOper(userrec* user)
 {
         for (std::vector<userrec*>::iterator a = all_opers.begin(); a < all_opers.end(); a++)
@@ -239,6 +264,7 @@ void ReadConfig(bool bail, userrec* user)
        char AH[MAXBUF],AP[MAXBUF],AF[MAXBUF],DNT[MAXBUF],pfreq[MAXBUF],thold[MAXBUF],sqmax[MAXBUF],rqmax[MAXBUF];
        ConnectClass c;
        std::stringstream errstr;
+       include_stack.clear();
        
        if (!LoadConf(CONFIG_FILE,&config_f,&errstr))
        {
@@ -514,9 +540,9 @@ chanrec* add_channel(userrec *user, const char* cn, const char* key, bool overri
        // we MUST declare this wherever we use FOREACH_RESULT
        int MOD_RESULT = 0;
 
-       if (strlen(cname) > CHANMAX-1)
+       if (strlen(cname) > CHANMAX)
        {
-               cname[CHANMAX-1] = '\0';
+               cname[CHANMAX] = '\0';
        }
 
        log(DEBUG,"add_channel: %s %s",user->nick,cname);
@@ -1130,7 +1156,9 @@ void kill_link(userrec *user,const char* r)
        // if they were an oper with +s.
         if (user->registered == 7) {
                 purge_empty_chans(user);
-               WriteOpers("*** Client exiting: %s!%s@%s [%s]",user->nick,user->ident,user->host,reason);
+               // fix by brain: only show local quits because we only show local connects (it just makes SENSE)
+               if (!strcmp(user->server,ServerName))
+                       WriteOpers("*** Client exiting: %s!%s@%s [%s]",user->nick,user->ident,user->host,reason);
                AddWhoWas(user);
        }
 
@@ -1306,10 +1334,10 @@ void AddWhoWas(userrec* u)
        whowas_hash::iterator iter = whowas.find(u->nick);
        WhoWasUser *a = new WhoWasUser();
        strlcpy(a->nick,u->nick,NICKMAX);
-       strlcpy(a->ident,u->ident,15);
+       strlcpy(a->ident,u->ident,IDENTMAX);
        strlcpy(a->dhost,u->dhost,160);
        strlcpy(a->host,u->host,160);
-       strlcpy(a->fullname,u->fullname,128);
+       strlcpy(a->fullname,u->fullname,MAXGECOS);
        strlcpy(a->server,u->server,256);
        a->signon = u->signon;
 
@@ -1393,16 +1421,16 @@ void AddClient(int socket, char* host, int port, bool iscached, char* ip)
        log(DEBUG,"AddClient: %lu %s %d %s",(unsigned long)socket,host,port,ip);
 
        clientlist[tempnick]->fd = socket;
-       strncpy(clientlist[tempnick]->nick, tn2,NICKMAX);
-       strncpy(clientlist[tempnick]->host, host,160);
-       strncpy(clientlist[tempnick]->dhost, host,160);
-       strncpy(clientlist[tempnick]->server, ServerName,256);
-       strncpy(clientlist[tempnick]->ident, "unknown",15);
+       strlcpy(clientlist[tempnick]->nick, tn2,NICKMAX);
+       strlcpy(clientlist[tempnick]->host, host,160);
+       strlcpy(clientlist[tempnick]->dhost, host,160);
+       clientlist[tempnick]->server = (char*)FindServerNamePtr(ServerName);
+       strlcpy(clientlist[tempnick]->ident, "unknown",IDENTMAX);
        clientlist[tempnick]->registered = 0;
        clientlist[tempnick]->signon = TIME+dns_timeout;
        clientlist[tempnick]->lastping = 1;
        clientlist[tempnick]->port = port;
-       strncpy(clientlist[tempnick]->ip,ip,16);
+       strlcpy(clientlist[tempnick]->ip,ip,16);
 
        // set the registration timeout for this user
        unsigned long class_regtimeout = 90;
@@ -1579,6 +1607,7 @@ void FullConnectUser(userrec* user)
 
        // fix by brain: these should be AFTER the N token, so other servers know what the HELL we're on about... :)
        FOREACH_MOD OnUserConnect(user);
+       FOREACH_MOD OnGlobalConnect(user);
        WriteOpers("*** Client connecting on port %lu: %s!%s@%s [%s]",(unsigned long)user->port,user->nick,user->ident,user->host,user->ip);
 }
 
@@ -1742,6 +1771,7 @@ void DoSplitEveryone()
                        }
                }
        }
+       has_been_netsplit = true;
 }
 
 
@@ -2037,21 +2067,18 @@ void process_command(userrec *user, char* cmd)
                                        }
                                        if ((user->registered == 7) && (!strchr(user->modes,'o')))
                                        {
-                                               char* mycmd;
-                                               char* savept2;
-                                               mycmd = strtok_r(DisabledCommands," ",&savept2);
-                                               while (mycmd)
+                                               std::stringstream dcmds(DisabledCommands);
+                                               while (!dcmds.eof())
                                                {
-                                                       if (!strcasecmp(mycmd,command))
+                                                       std::string thiscmd;
+                                                       dcmds >> thiscmd;
+                                                       if (!strcasecmp(thiscmd.c_str(),command))
                                                        {
                                                                // command is disabled!
                                                                WriteServ(user->fd,"421 %s %s :This command has been disabled.",user->nick,command);
                                                                return;
                                                        }
-                                                       mycmd = strtok_r(NULL," ",&savept2);
                                                }
-        
-
                                        }
                                        if ((user->registered == 7) || (!strncmp(command,"USER",4)) || (!strncmp(command,"NICK",4)) || (!strncmp(command,"PASS",4)))
                                        {
@@ -2341,6 +2368,7 @@ void DoSplit(const char* params)
                        }
                }
        }
+       has_been_netsplit = true;
 }
 
 // removes a server. Will NOT remove its users!
@@ -2583,6 +2611,8 @@ int InspIRCd(char** argv, int argc)
        }  
        log(DEBUG,"InspIRCd: startup: read config");
 
+       AddServerName(ServerName);
+
        int clientportcount = 0, serverportcount = 0;
 
        for (count = 0; count < ConfValueEnum("bind",&config_f); count++)
@@ -2940,6 +2970,7 @@ int InspIRCd(char** argv, int argc)
                        msgs.clear();
                        while ((me[x]) && (me[x]->RecvPacket(msgs, tcp_host, sums))) // returns 0 or more lines (can be multiple lines!)
                        {
+                               has_been_netsplit = false;
                                for (int ctr = 0; ctr < msgs.size(); ctr++)
                                {
                                        strlcpy(tcp_msg,msgs[ctr].c_str(),MAXBUF);
@@ -2974,8 +3005,7 @@ int InspIRCd(char** argv, int argc)
                                                goto label;
                                        }
                                }
-                                       sums.clear();   // we're done, clear the list for the next operation
-                                       msgs.clear();
+                               goto label;
                        }
                }