]> git.netwichtig.de Git - user/henk/code/inspircd.git/blobdiff - src/users.cpp
kick_channel -> chanrec::KickUser(), server_kick_channel -> chanrec::ServerKickUser()
[user/henk/code/inspircd.git] / src / users.cpp
index 85d64d4623c760c7ff38fb433f6cb73a9a57b2f5..34c347cb934deac5aaa0a576a1383801fa20e7cd 100644 (file)
@@ -178,7 +178,11 @@ void UserResolver::OnLookupComplete(const std::string &result)
                        std::string hostname = this->bound_user->stored_host;
                        if (hostname.length() < 65)
                        {
-                               WriteServ(this->bound_fd, "NOTICE Auth :*** Found your hostname (%s)", this->bound_user->stored_host.c_str());
+                               /* Hostnames starting with : are not a good thing (tm) */
+                               if (*(hostname.c_str()) == ':')
+                                       hostname = "0" + hostname;
+
+                               WriteServ(this->bound_fd, "NOTICE Auth :*** Found your hostname (%s)", hostname.c_str());
                                this->bound_user->dns_done = true;
                                strlcpy(this->bound_user->dhost, hostname.c_str(),64);
                                strlcpy(this->bound_user->host, hostname.c_str(),64);
@@ -267,7 +271,9 @@ userrec::userrec()
        haspassed = dns_done = false;
        recvq = "";
        sendq = "";
+       WriteError = "";
        res_forward = res_reverse = NULL;
+       ip = NULL;
        chans.clear();
        invites.clear();
        chans.resize(MAXCHANS);
@@ -289,6 +295,20 @@ userrec::~userrec()
                ucrec* x = (ucrec*)*n;
                delete x;
        }
+
+       if (ip)
+       {
+               if (this->GetProtocolFamily() == AF_INET)
+               {
+                       delete (sockaddr_in*)ip;
+               }
+#ifdef SUPPORT_IP6LINKS
+               else
+               {
+                       delete (sockaddr_in6*)ip;
+               }
+#endif
+       }
 }
 
 /* XXX - minor point, other *Host functions return a char *, this one creates it. Might be nice to be consistant? */
@@ -581,6 +601,7 @@ void userrec::FlushWriteBuf()
 
 void userrec::SetWriteError(const std::string &error)
 {
+       log(DEBUG,"SetWriteError: %s",error.c_str());
        // don't try to set the error twice, its already set take the first string.
        if (!this->WriteError.length())
        {
@@ -797,11 +818,6 @@ void AddClient(int socket, int port, bool iscached, insp_inaddr ip)
        _new->fd = socket;
        strlcpy(_new->nick,tempnick.c_str(),NICKMAX-1);
 
-       /* Smarter than your average bear^H^H^H^Hset of strlcpys. */
-       for (const char* temp = ipaddr; *temp && j < 64; temp++, j++)
-               _new->dhost[j] = _new->host[j] = *temp;
-       _new->dhost[j] = _new->host[j] = 0;
-
        _new->server = FindServerNamePtr(Config->ServerName);
        /* We don't need range checking here, we KNOW 'unknown\0' will fit into the ident field. */
        strcpy(_new->ident, "unknown");
@@ -809,8 +825,16 @@ void AddClient(int socket, int port, bool iscached, insp_inaddr ip)
        _new->registered = REG_NONE;
        _new->signon = TIME + Config->dns_timeout;
        _new->lastping = 1;
+
+       log(DEBUG,"Setting socket addresses");
        _new->SetSockAddr(AF_FAMILY, ipaddr, port);
+       log(DEBUG,"Socket addresses set.");
 
+       /* Smarter than your average bear^H^H^H^Hset of strlcpys. */
+        for (const char* temp = _new->GetIPString(); *temp && j < 64; temp++, j++)
+               _new->dhost[j] = _new->host[j] = *temp;
+       _new->dhost[j] = _new->host[j] = 0;
+                       
        // set the registration timeout for this user
        unsigned long class_regtimeout = 90;
        int class_flood = 0;
@@ -820,7 +844,7 @@ void AddClient(int socket, int port, bool iscached, insp_inaddr ip)
 
        for (ClassVector::iterator i = Config->Classes.begin(); i != Config->Classes.end(); i++)
        {
-               if ((i->type == CC_ALLOW) && (match(ipaddr,i->host.c_str())))
+               if ((i->type == CC_ALLOW) && (match(ipaddr,i->host.c_str(),true)))
                {
                        class_regtimeout = (unsigned long)i->registration_timeout;
                        class_flood = i->flood;
@@ -884,7 +908,11 @@ void AddClient(int socket, int port, bool iscached, insp_inaddr ip)
 
        if (socket > -1)
        {
-               ServerInstance->SE->AddFd(socket,true,X_ESTAB_CLIENT);
+               if (!ServerInstance->SE->AddFd(socket,true,X_ESTAB_CLIENT))
+               {
+                       kill_link(_new, "Internal error handling connection");
+                       return;
+               }
        }
 
        WriteServ(_new->fd,"NOTICE Auth :*** Looking up your hostname...");
@@ -892,23 +920,16 @@ void AddClient(int socket, int port, bool iscached, insp_inaddr ip)
 
 long FindMatchingGlobal(userrec* user)
 {
+       char u1[1024];
+       char u2[1024];
        long x = 0;
        for (user_hash::const_iterator a = clientlist.begin(); a != clientlist.end(); a++)
        {
-#ifdef IPV6
-               /* I dont think theres any faster way of matching two ipv6 addresses than memcmp
-                * Let me know if you think of one.
-                 */
-               in6_addr* s1 = &(((sockaddr_in6*)&a->second->ip)->sin6_addr);
-               in6_addr* s2 = &(((sockaddr_in6*)&user->ip)->sin6_addr);
-               if (!memcmp(s1->s6_addr, s2->s6_addr, sizeof(in6_addr)))
-                       x++;
-#else
-               in_addr* s1 = &((sockaddr_in*)&a->second->ip)->sin_addr;
-               in_addr* s2 = &((sockaddr_in*)&user->ip)->sin_addr;
-               if (s1->s_addr == s2->s_addr)
-                       x++;
-#endif
+               /* We have to match ip's as strings - we don't know what protocol
+                * a remote user may be using
+                */
+               if (!strcasecmp(a->second->GetIPString(u1), user->GetIPString(u2)))
+                               x++;
        }
        return x;
 }
@@ -921,13 +942,13 @@ long FindMatchingLocal(userrec* user)
                userrec* comp = *a;
 #ifdef IPV6
                /* I dont think theres any faster way of matching two ipv6 addresses than memcmp */
-               in6_addr* s1 = &(((sockaddr_in6*)&comp->ip)->sin6_addr);
-               in6_addr* s2 = &(((sockaddr_in6*)&user->ip)->sin6_addr);
+               in6_addr* s1 = &(((sockaddr_in6*)comp->ip)->sin6_addr);
+               in6_addr* s2 = &(((sockaddr_in6*)user->ip)->sin6_addr);
                if (!memcmp(s1->s6_addr, s2->s6_addr, sizeof(in6_addr)))
                        x++;
 #else
-               in_addr* s1 = &((sockaddr_in*)&comp->ip)->sin_addr;
-               in_addr* s2 = &((sockaddr_in*)&user->ip)->sin_addr;
+               in_addr* s1 = &((sockaddr_in*)comp->ip)->sin_addr;
+               in_addr* s2 = &((sockaddr_in*)user->ip)->sin_addr;
                if (s1->s_addr == s2->s_addr)
                        x++;
 #endif
@@ -1111,20 +1132,26 @@ void userrec::SetSockAddr(int protocol_family, const char* ip, int port)
 {
        switch (protocol_family)
        {
+#ifdef SUPPORT_IP6LINKS
                case AF_INET6:
                {
-                       sockaddr_in6* sin = (sockaddr_in6*)&this->ip;
+                       log(DEBUG,"Set inet6 protocol address");
+                       sockaddr_in6* sin = new sockaddr_in6;
                        sin->sin6_family = AF_INET6;
                        sin->sin6_port = port;
                        inet_pton(AF_INET6, ip, &sin->sin6_addr);
+                       this->ip = (sockaddr*)sin;
                }
                break;
+#endif
                case AF_INET:
                {
-                       sockaddr_in* sin = (sockaddr_in*)&this->ip;
+                       log(DEBUG,"Set inet4 protocol address");
+                       sockaddr_in* sin = new sockaddr_in;
                        sin->sin_family = AF_INET;
                        sin->sin_port = port;
                        inet_pton(AF_INET, ip, &sin->sin_addr);
+                       this->ip = (sockaddr*)sin;
                }
                break;
                default:
@@ -1135,17 +1162,22 @@ void userrec::SetSockAddr(int protocol_family, const char* ip, int port)
 
 int userrec::GetPort()
 {
+       if (this->ip == NULL)
+               return 0;
+
        switch (this->GetProtocolFamily())
        {
+#ifdef SUPPORT_IP6LINKS
                case AF_INET6:
                {
-                       sockaddr_in6* sin = (sockaddr_in6*)&this->ip;
+                       sockaddr_in6* sin = (sockaddr_in6*)this->ip;
                        return sin->sin6_port;
                }
                break;
+#endif
                case AF_INET:
                {
-                       sockaddr_in* sin = (sockaddr_in*)&this->ip;
+                       sockaddr_in* sin = (sockaddr_in*)this->ip;
                        return sin->sin_port;
                }
                break;
@@ -1158,26 +1190,42 @@ int userrec::GetPort()
 
 int userrec::GetProtocolFamily()
 {
-       sockaddr_in* sin = (sockaddr_in*)&this->ip;
+       if (this->ip == NULL)
+               return 0;
+
+       sockaddr_in* sin = (sockaddr_in*)this->ip;
        return sin->sin_family;
 }
 
 const char* userrec::GetIPString()
 {
        static char buf[1024];
+       static char temp[1024];
+
+       if (this->ip == NULL)
+               return "";
 
        switch (this->GetProtocolFamily())
        {
+#ifdef SUPPORT_IP6LINKS
                case AF_INET6:
                {
-                       sockaddr_in6* sin = (sockaddr_in6*)&this->ip;
+                       sockaddr_in6* sin = (sockaddr_in6*)this->ip;
                        inet_ntop(sin->sin6_family, &sin->sin6_addr, buf, sizeof(buf));
+                       /* IP addresses starting with a : on irc are a Bad Thing (tm) */
+                       if (*buf == ':')
+                       {
+                               strlcpy(&temp[1], buf, sizeof(temp));
+                               *temp = '0';
+                               return temp;
+                       }
                        return buf;
                }
                break;
+#endif
                case AF_INET:
                {
-                       sockaddr_in* sin = (sockaddr_in*)&this->ip;
+                       sockaddr_in* sin = (sockaddr_in*)this->ip;
                        inet_ntop(sin->sin_family, &sin->sin_addr, buf, sizeof(buf));
                        return buf;
                }
@@ -1189,3 +1237,46 @@ const char* userrec::GetIPString()
        return "";
 }
 
+const char* userrec::GetIPString(char* buf)
+{
+       static char temp[1024];
+
+       if (this->ip == NULL)
+       {
+               *buf = 0;
+               return buf;
+       }
+
+       switch (this->GetProtocolFamily())
+       {
+#ifdef SUPPORT_IP6LINKS
+               case AF_INET6:
+               {
+                       sockaddr_in6* sin = (sockaddr_in6*)this->ip;
+                       inet_ntop(sin->sin6_family, &sin->sin6_addr, buf, sizeof(buf));
+                       /* IP addresses starting with a : on irc are a Bad Thing (tm) */
+                       if (*buf == ':')
+                       {
+                               strlcpy(&temp[1], buf, sizeof(temp));
+                               *temp = '0';
+                               strlcpy(buf, temp, sizeof(temp));
+                       }
+                       return buf;
+               }
+               break;
+#endif
+               case AF_INET:
+               {
+                       sockaddr_in* sin = (sockaddr_in*)this->ip;
+                       inet_ntop(sin->sin_family, &sin->sin_addr, buf, sizeof(buf));
+                       return buf;
+               }
+               break;
+
+               default:
+                       log(DEBUG,"Ut oh, '%s' has an unknown protocol family!",this->nick);
+               break;
+       }
+       return "";
+}
+