X-Git-Url: https://vcs.fsf.org/?a=blobdiff_plain;f=src%2Fsrc%2Fspam.c;h=beec82363a16f7852b2d3a1db5614d0365ef63ab;hb=c4c02c552afaadc2a78b9df2aa22559dd1587f40;hp=70020060564a0e40488c208a1030ad50b5bc0d8e;hpb=91ecef39cad37bb5de008f557bded8dcbc8aa6e3;p=exim.git diff --git a/src/src/spam.c b/src/src/spam.c index 700200605..beec82363 100644 --- a/src/src/spam.c +++ b/src/src/spam.c @@ -1,4 +1,4 @@ -/* $Cambridge: exim/src/src/spam.c,v 1.13 2006/09/05 14:05:43 ph10 Exp $ */ +/* $Cambridge: exim/src/src/spam.c,v 1.17 2008/07/18 17:55:42 fanf2 Exp $ */ /************************************************* * Exim - an Internet mail transport agent * @@ -46,6 +46,7 @@ int spam(uschar **listptr) { struct timeval select_tv; /* and applied by PH */ fd_set select_fd; #endif + uschar *spamd_address_work; /* stop compiler warning */ result = 0; @@ -89,14 +90,26 @@ int spam(uschar **listptr) { }; start = time(NULL); + + if (*spamd_address == '$') { + spamd_address_work = expand_string(spamd_address); + if (spamd_address_work == NULL) { + log_write(0, LOG_MAIN|LOG_PANIC, + "spamassassin acl condition: spamd_address starts with $, but expansion failed: %s", expand_string_message); + return DEFER; + } + } + else + spamd_address_work = spamd_address; + /* socket does not start with '/' -> network socket */ - if (*spamd_address != '/') { + if (*spamd_address_work != '/') { time_t now = time(NULL); int num_servers = 0; int current_server = 0; int start_server = 0; uschar *address = NULL; - uschar *spamd_address_list_ptr = spamd_address; + uschar *spamd_address_list_ptr = spamd_address_work; uschar address_buffer[256]; spamd_address_container * spamd_address_vector[32]; @@ -184,12 +197,12 @@ int spam(uschar **listptr) { } server.sun_family = AF_UNIX; - Ustrcpy(server.sun_path, spamd_address); + Ustrcpy(server.sun_path, spamd_address_work); if (connect(spamd_sock, (struct sockaddr *) &server, sizeof(struct sockaddr_un)) < 0) { log_write(0, LOG_MAIN|LOG_PANIC, "malware acl condition: spamd: unable to connect to UNIX socket %s (%s)", - spamd_address, strerror(errno) ); + spamd_address_work, strerror(errno) ); (void)fclose(mbox_file); (void)close(spamd_sock); return DEFER; @@ -316,11 +329,11 @@ again: (void)close(spamd_sock); /* dig in the spamd output and put the report in a multiline header, if requested */ - if( sscanf(CS spamd_buffer,"SPAMD/%s 0 EX_OK\r\nContent-length: %*u\r\n\r\n%lf/%lf\r\n%n", + if( sscanf(CS spamd_buffer,"SPAMD/%7s 0 EX_OK\r\nContent-length: %*u\r\n\r\n%lf/%lf\r\n%n", spamd_version,&spamd_score,&spamd_threshold,&spamd_report_offset) != 3 ) { /* try to fall back to pre-2.50 spamd output */ - if( sscanf(CS spamd_buffer,"SPAMD/%s 0 EX_OK\r\nSpam: %*s ; %lf / %lf\r\n\r\n%n", + if( sscanf(CS spamd_buffer,"SPAMD/%7s 0 EX_OK\r\nSpam: %*s ; %lf / %lf\r\n\r\n%n", spamd_version,&spamd_score,&spamd_threshold,&spamd_report_offset) != 3 ) { log_write(0, LOG_MAIN|LOG_PANIC, "spam acl condition: cannot parse spamd output"); @@ -341,13 +354,10 @@ again: *q = *p; q++; if (*p == '\n') { - *q = '\t'; + /* add an extra space after the newline to ensure + that it is treated as a header continuation line */ + *q = ' '; q++; - /* eat whitespace */ - while( (*p <= ' ') && (*p != '\0') ) { - p++; - }; - p--; }; p++; }; @@ -395,9 +405,11 @@ again: spam_rc = FAIL; }; - /* remember user name and "been here" for it */ - Ustrcpy(prev_user_name, user_name); - spam_ok = 1; + /* remember user name and "been here" for it unless spamd_socket was expanded */ + if (spamd_address_work == spamd_address) { + Ustrcpy(prev_user_name, user_name); + spam_ok = 1; + } if (override) { /* always return OK, no matter what the score */