X-Git-Url: https://code.citadel.org/?a=blobdiff_plain;f=citadel%2Fdomain.c;h=0522c17fdf4e5a8c091aac3f16af5a7cad99e4b6;hb=56d69e5d8434e98835a2582c59b771ba69475431;hp=c02aa303cae3c64686d573874a0a8b2d10ec18d8;hpb=3018b378044bf8351a2d843864740e6ca244989c;p=citadel.git diff --git a/citadel/domain.c b/citadel/domain.c index c02aa303c..0522c17fd 100644 --- a/citadel/domain.c +++ b/citadel/domain.c @@ -1,12 +1,102 @@ +/* + * DNS lookup for SMTP sender + * + * Copyright (c) 1987-2009 by the citadel.org team + * + * This program is free 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" #include #include +#include #include +#include + +#ifdef HAVE_RESOLV_H #include +#ifdef HAVE_ARPA_NAMESER_COMPAT_H +#include +#endif #include +#endif +#include #include "sysdep_decls.h" +#include "citadel.h" #include "domain.h" +#include "server.h" +#include "internet_addressing.h" + + +/* + * get_hosts() checks the Internet configuration for various types of + * entries and returns them in the same format as getmx() does -- fill the + * buffer with a delimited list of hosts and return the number of hosts. + * + * This is used to fetch MX smarthosts, SpamAssassin hosts, etc. + */ +int get_hosts(char *mxbuf, char *rectype) { + int config_lines; + int i; + char buf[256]; + char host[256], type[256]; + int total_smarthosts = 0; + + if (inetcfg == NULL) return(0); + strcpy(mxbuf, ""); + + config_lines = num_tokens(inetcfg, '\n'); + for (i=0; ipref; + pref2 = ((const struct mx *)mx2)->pref; + + if (pref1 > pref2) { + return(1); + } + else if (pref1 < pref2) { + return(0); + } + else { + return(rand() % 2); + } +} -#define SMART_HOST "gatekeeper.wdcs.com" /* * getmx() @@ -19,77 +109,121 @@ * */ int getmx(char *mxbuf, char *dest) { - char answer[1024]; + +#ifdef HAVE_RESOLV_H + union { + u_char bytes[1024]; + HEADER header; + } answer; +#endif + int ret; unsigned char *startptr, *endptr, *ptr; - int expanded_size; char expanded_buf[1024]; unsigned short pref, type; - int n; - + int n = 0; + int qdcount; + struct mx *mxrecs = NULL; + int num_mxrecs = 0; + /* If we're configured to send all mail to a smart-host, then our * job here is really easy. */ - if (1) { /* FIX */ - strcpy(mxbuf, SMART_HOST); - return(1); - } + n = get_hosts(mxbuf, "smarthost"); + if (n > 0) return(n); - /* No smart-host? Look up the best MX for a site. + /* + * No smart-host? Look up the best MX for a site. + * Make a call to the resolver library. */ + ret = res_query( dest, - C_IN, T_MX, answer, sizeof(answer) ); - - lprintf(9, "res_query() returned %d\n", ret); + C_IN, T_MX, (unsigned char *)answer.bytes, sizeof(answer) ); if (ret < 0) { - lprintf(5, "No MX found\n"); - return(0); + mxrecs = malloc(sizeof(struct mx)); + mxrecs[0].pref = 0; + strcpy(mxrecs[0].host, dest); + num_mxrecs = 1; } - - /* If we had to truncate, shrink the number to avoid fireworks */ - if (ret > sizeof(answer)) - ret = sizeof(answer); - lprintf(9, "size of answer is %d\n", ret); - - startptr = &answer[0]; /* start and end of buffer */ - endptr = &answer[ret]; - - ptr = startptr + HFIXEDSZ; /* advance past header */ - - while(1) { - memset(expanded_buf, 0, sizeof(expanded_buf)); - ret = dn_expand(startptr, - endptr, - ptr, - expanded_buf, - sizeof(expanded_buf) - ); - if (ret < 0) break; - ptr += ret; - - GETSHORT(type, ptr); - ptr += INT16SZ + INT32SZ; - GETSHORT(n, ptr); - ptr += n; - - lprintf(9, "ret=%d, type=%d\n", ret, type); + else { + + /* If we had to truncate, shrink the number to avoid fireworks */ + if (ret > sizeof(answer)) + ret = sizeof(answer); + + startptr = &answer.bytes[0]; /* start and end of buffer */ + endptr = &answer.bytes[ret]; + ptr = startptr + HFIXEDSZ; /* advance past header */ + + for (qdcount = ntohs(answer.header.qdcount); qdcount--; ptr += ret + QFIXEDSZ) { + if ((ret = dn_skipname(ptr, endptr)) < 0) { + CtdlLogPrintf(CTDL_DEBUG, "dn_skipname error\n"); + return(0); + } + } + + while(1) { + memset(expanded_buf, 0, sizeof(expanded_buf)); + ret = dn_expand(startptr, + endptr, + ptr, + expanded_buf, + sizeof(expanded_buf) + ); + if (ret < 0) break; + ptr += ret; + + GETSHORT(type, ptr); + ptr += INT16SZ + INT32SZ; + GETSHORT(n, ptr); + + if (type != T_MX) { + ptr += n; + } + + else { + GETSHORT(pref, ptr); + ret = dn_expand(startptr, + endptr, + ptr, + expanded_buf, + sizeof(expanded_buf) + ); + ptr += ret; + + ++num_mxrecs; + if (mxrecs == NULL) { + mxrecs = malloc(sizeof(struct mx)); + } + else { + mxrecs = realloc(mxrecs, + (sizeof(struct mx) * num_mxrecs) ); + } + + mxrecs[num_mxrecs - 1].pref = pref; + strcpy(mxrecs[num_mxrecs - 1].host, + expanded_buf); + } + } } + /* Sort the MX records by preference */ + if (num_mxrecs > 1) { + qsort(mxrecs, num_mxrecs, sizeof(struct mx), mx_compare_pref); + } + strcpy(mxbuf, ""); + for (n=0; n