Fix warnings all over citserver; handle function replies; remove unused code.
[citadel.git] / citadel / locate_host.c
index 0331d82df174d7b8efbfa95ea47593f554fa276d..2a7568b232e4ce1fbb05d6f05c7e88fe154ccf1c 100644 (file)
@@ -1,8 +1,21 @@
 /*
- * $Id$
- *
  * Functions which handle hostname/address lookups and resolution
  *
+ * Copyright (c) 1987-2011 by the citadel.org team
+ *
+ * This program is open source software; you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation; either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with this program; if not, write to the Free Software
+ * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
  */
 
 #include "sysdep.h"
@@ -19,6 +32,7 @@
 #include <netdb.h>
 #include <string.h>
 #include <errno.h>
+#include <syslog.h>
 #include <libcitadel.h>
 #include "citadel.h"
 #include "server.h"
 #endif
 
 
+/*
+ * Given an open client socket, return the host name and IP address at the other end.
+ * (IPv4 and IPv6 compatible)
+ */
 void locate_host(char *tbuf, size_t n, char *abuf, size_t na, int client_socket)
 {
        struct sockaddr_in6 clientaddr;
@@ -49,6 +67,16 @@ void locate_host(char *tbuf, size_t n, char *abuf, size_t na, int client_socket)
        getpeername(client_socket, (struct sockaddr *)&clientaddr, &addrlen);
        getnameinfo((struct sockaddr *)&clientaddr, addrlen, tbuf, n, NULL, 0, 0);
        getnameinfo((struct sockaddr *)&clientaddr, addrlen, abuf, na, NULL, 0, NI_NUMERICHOST);
+
+       /* Convert IPv6-mapped IPv4 addresses back to traditional dotted quad.
+        *
+        * Other code here, such as the RBL check, will expect IPv4 addresses to be represented
+        * as dotted-quad, even if they come in over a hybrid IPv6/IPv4 socket.
+        */
+       if ( (strlen(abuf) > 7) && (!strncasecmp(abuf, "::ffff:", 7)) ) {
+               if (!strcmp(abuf, tbuf)) strcpy(tbuf, &tbuf[7]);
+               strcpy(abuf, &abuf[7]);
+       }
 }
 
 
@@ -68,20 +96,26 @@ int rblcheck_backend(char *domain, char *txtbuf, int txtbufsize) {
        const u_char *rend;
        int len;
        char *p = NULL;
+       static int res_initted = 0;
+
+       if (!res_initted) {             /* only have to do this once */
+               res_init();
+               res_initted = 1;
+       }
 
        /* Make our DNS query. */
-       //res_init();
        answer = fixedans;
-       if (CtdlThreadCheckStop())
+       if (server_shutting_down)
        {
-               if (txtbuf != NULL)
+               if (txtbuf != NULL) {
                        snprintf(txtbuf, txtbufsize, "System shutting down");
+               }
                return (1);
        }
-       len = res_query( domain, C_IN, T_A, answer, PACKETSZ );
+       len = res_query(domain, C_IN, T_A, answer, PACKETSZ);
 
        /* Was there a problem? If so, the domain doesn't exist. */
-       if( len == -1 ) {
+       if (len == -1) {
                if (txtbuf != NULL) {
                        strcpy(txtbuf, "");
                }
@@ -90,9 +124,9 @@ int rblcheck_backend(char *domain, char *txtbuf, int txtbufsize) {
 
        if( len > PACKETSZ )
        {
-               answer = malloc( len );
+               answer = malloc(len);
                need_to_free_answer = 1;
-               len = res_query( domain, C_IN, T_A, answer, len );
+               len = res_query(domain, C_IN, T_A, answer, len);
                if( len == -1 ) {
                        if (txtbuf != NULL) {
                                snprintf(txtbuf, txtbufsize,
@@ -102,7 +136,7 @@ int rblcheck_backend(char *domain, char *txtbuf, int txtbufsize) {
                        return(1);
                }
        }
-       if (CtdlThreadCheckStop())
+       if (server_shutting_down)
        {
                if (txtbuf != NULL)
                        snprintf(txtbuf, txtbufsize, "System shutting down");
@@ -110,26 +144,27 @@ int rblcheck_backend(char *domain, char *txtbuf, int txtbufsize) {
                return (1);
        }
 
-       result = ( char * )malloc( RESULT_SIZE );
+       result = (char *) malloc(RESULT_SIZE);
        result[ 0 ] = '\0';
 
 
        /* Make another DNS query for textual data; this shouldn't
-          be a performance hit, since it'll now be cached at the
-          nameserver we're using. */
-       res_init();
-       len = res_query( domain, C_IN, T_TXT, answer, PACKETSZ );
-       if (CtdlThreadCheckStop())
+        * be a performance hit, since it'll now be cached at the
+        * nameserver we're using.
+        */
+       len = res_query(domain, C_IN, T_TXT, answer, PACKETSZ);
+       if (server_shutting_down)
        {
-               if (txtbuf != NULL)
+               if (txtbuf != NULL) {
                        snprintf(txtbuf, txtbufsize, "System shutting down");
+               }
                if (need_to_free_answer) free(answer);
                free(result);
                return (1);
        }
 
        /* Just in case there's no TXT record... */
-       if( len == -1 )
+       if (len ==(-1))
        {
                if (txtbuf != NULL) {
                        snprintf(txtbuf, txtbufsize,
@@ -150,32 +185,32 @@ int rblcheck_backend(char *domain, char *txtbuf, int txtbufsize) {
        }
 
        /* This seems to be a bit of magic data that we need to
-          skip. I wish there were good online documentation
-          for programming for libresolv, so I'd know what I'm
-          skipping here. Anyone reading this, feel free to
-          enlighten me. */
+        * skip. I wish there were good online documentation
+        * for programming for libresolv, so I'd know what I'm
+        * skipping here. Anyone reading this, feel free to
+        * enlighten me.
+        */
        cp += 1 + NS_INT16SZ + NS_INT32SZ;
 
        /* Skip the type, class and ttl. */
-       cp += ( NS_INT16SZ * 2 ) + NS_INT32SZ;
+       cp += (NS_INT16SZ * 2) + NS_INT32SZ;
 
        /* Get the length and end of the buffer. */
-       NS_GET16( c, cp );
+       NS_GET16(c, cp);
        cend = cp + c;
 
        /* Iterate over any multiple answers we might have. In
-          this context, it's unlikely, but anyway. */
+        * this context, it's unlikely, but anyway.
+        */
        rp = (u_char *) result;
        rend = (u_char *) result + RESULT_SIZE - 1;
-       while( cp < cend && rp < rend )
+       while (cp < cend && rp < rend)
        {
                a = *cp++;
                if( a != 0 )
-                       for( b = a; b > 0 && cp < cend && rp < rend;
-                         b-- )
+                       for (b = a; b > 0 && cp < cend && rp < rend; b--)
                        {
-                               if( *cp == '\n' || *cp == '"' ||
-                                 *cp == '\\' )
+                               if (*cp == '\n' || *cp == '"' || *cp == '\\')
                                {
                                        *rp++ = '\\';
                                }
@@ -197,22 +232,72 @@ int rblcheck_backend(char *domain, char *txtbuf, int txtbufsize) {
 
 
 /*
- * Check to see if a host is on some sort of spam list (RBL)
+ * Check to see if the client host is on some sort of spam list (RBL)
  * If spammer, returns nonzero and places reason in 'message_to_spammer'
  */
-int rbl_check_addr(struct in_addr *addr, char *message_to_spammer)
+int rbl_check(char *message_to_spammer)
 {
-       int a1, a2, a3, a4;
-       char tbuf[256];
+       char tbuf[256] = "";
+       int suffix_pos = 0;
        int rbl;
        int num_rbl;
        char rbl_domains[SIZ];
        char txt_answer[1024];
-       char dotted_quad[32];
 
        strcpy(message_to_spammer, "ok");
-       safestrncpy(dotted_quad, inet_ntoa(*addr), sizeof dotted_quad);
-       sscanf(dotted_quad, "%d.%d.%d.%d", &a1, &a2, &a3, &a4);
+
+       if ((strchr(CC->cs_addr, '.')) && (!strchr(CC->cs_addr, ':'))) {
+               int a1, a2, a3, a4;
+
+               sscanf(CC->cs_addr, "%d.%d.%d.%d", &a1, &a2, &a3, &a4);
+               snprintf(tbuf, sizeof tbuf, "%d.%d.%d.%d.", a4, a3, a2, a1);
+               suffix_pos = strlen(tbuf);
+       }
+       else if ((!strchr(CC->cs_addr, '.')) && (strchr(CC->cs_addr, ':'))) {
+               int num_colons = 0;
+               int i = 0;
+               char workbuf[sizeof tbuf];
+               char *ptr;
+
+               /* tedious code to expand and reverse an IPv6 address */
+               safestrncpy(tbuf, CC->cs_addr, sizeof tbuf);
+               num_colons = haschar(tbuf, ':');
+               if ((num_colons < 2) || (num_colons > 7)) return(0);    /* badly formed address */
+
+               /* expand the "::" shorthand */
+               while (num_colons < 7) {
+                       ptr = strstr(tbuf, "::");
+                       if (!ptr) return(0);                            /* badly formed address */
+                       ++ptr;
+                       strcpy(workbuf, ptr);
+                       strcpy(ptr, ":");
+                       strcat(ptr, workbuf);
+                       ++num_colons;
+               }
+
+               /* expand to 32 hex characters with no colons */
+               strcpy(workbuf, tbuf);
+               strcpy(tbuf, "00000000000000000000000000000000");
+               for (i=0; i<8; ++i) {
+                       char tokbuf[5];
+                       extract_token(tokbuf, workbuf, i, ':', sizeof tokbuf);
+
+                       memcpy(&tbuf[ (i*4) + (4-strlen(tokbuf)) ], tokbuf, strlen(tokbuf) );
+               }
+               if (strlen(tbuf) != 32) return(0);
+
+               /* now reverse it and add dots */
+               strcpy(workbuf, tbuf);
+               for (i=0; i<32; ++i) {
+                       tbuf[i*2] = workbuf[31-i];
+                       tbuf[(i*2)+1] = '.';
+               }
+               tbuf[64] = 0;
+               suffix_pos = 64;
+       }
+       else {
+               return(0);      /* unknown address format */
+       }
 
        /* See if we have any RBL domains configured */
        num_rbl = get_hosts(rbl_domains, "rbl");
@@ -220,14 +305,11 @@ int rbl_check_addr(struct in_addr *addr, char *message_to_spammer)
 
        /* Try all configured RBL's */
         for (rbl=0; rbl<num_rbl; ++rbl) {
-               snprintf(tbuf, sizeof tbuf,
-                       "%d.%d.%d.%d.",
-                       a4, a3, a2, a1);
-                extract_token(&tbuf[strlen(tbuf)], rbl_domains, rbl, '|', (sizeof tbuf - strlen(tbuf)));
+                extract_token(&tbuf[suffix_pos], rbl_domains, rbl, '|', (sizeof tbuf - suffix_pos));
 
                if (rblcheck_backend(tbuf, txt_answer, sizeof txt_answer)) {
                        strcpy(message_to_spammer, txt_answer);
-                       CtdlLogPrintf(CTDL_INFO, "RBL: %s\n", txt_answer);
+                       syslog(LOG_INFO, "RBL: %s\n", txt_answer);
                        return(1);
                }
        }
@@ -236,33 +318,11 @@ int rbl_check_addr(struct in_addr *addr, char *message_to_spammer)
 }
                        
 
-/*
- * Check to see if the client host is on some sort of spam list (RBL)
- * If spammer, returns nonzero and places reason in 'message_to_spammer'
- *
- * PORTABILITY NOTE!  I've made my best effort to rewrite this in a portable fashion.
- * If anyone makes changes to this function, please shout-out so we can test it to
- * make sure it didn't break on Linux!
- */
-int rbl_check(char *message_to_spammer) {
-       int r;
-       struct sockaddr_in peer;
-       socklen_t peer_len = 0;
-
-       peer_len = sizeof(peer);
-       r = getpeername(CC->client_socket, &peer, &peer_len);
-       if (r == 0) {
-               return(rbl_check_addr(&peer.sin_addr, message_to_spammer));
-       }
-       else {
-               CtdlLogPrintf(CTDL_INFO, "RBL getpeername() failed: %s\n", strerror(errno));
-       }
-       return(0);
-}
-
 /*
  * Convert a host name to a dotted quad address. 
  * Returns zero on success or nonzero on failure.
+ *
+ * FIXME this is obviously not IPv6 compatible.
  */
 int hostname_to_dotted_quad(char *addr, char *host) {
        struct hostent *ch;