]> Pileus Git - ~andy/fetchmail/blobdiff - sink.c
Ready to release.
[~andy/fetchmail] / sink.c
diff --git a/sink.c b/sink.c
index ff213e748bf044399dd5d32c791c28b06d78a1ff..151554a9ed092ac98b2821be2406d15b271df344 100644 (file)
--- a/sink.c
+++ b/sink.c
@@ -8,18 +8,12 @@
  *
  * Copyright 1998 by Eric S. Raymond
  * For license terms, see the file COPYING in this directory.
- *
- * i18n by Arnaldo Carvalho de Melo <acme@conectiva.com.br> 7-Nov-1998
  */
 
 #include  "config.h"
 #include  <stdio.h>
 #include  <errno.h>
 #include  <string.h>
-#include  <signal.h>
-#ifdef HAVE_MEMORY_H
-#include  <memory.h>
-#endif /* HAVE_MEMORY_H */
 #if defined(STDC_HEADERS)
 #include  <stdlib.h>
 #endif
 #include  "smtp.h"
 #include  "i18n.h"
 
-/* BSD portability hack...I know, this is an ugly place to put it */
-#if !defined(SIGCHLD) && defined(SIGCLD)
-#define SIGCHLD        SIGCLD
-#endif
+/* makes the open_sink()/close_sink() pair non-reentrant */
+static int lmtp_responses;
 
-static int smtp_open(struct query *ctl)
+int smtp_open(struct query *ctl)
 /* try to open a socket to the appropriate SMTP server for this query */ 
 {
     /* maybe it's time to close the socket in order to force delivery */
-    if (NUM_NONZERO(ctl->batchlimit) && (ctl->smtp_socket != -1) && batchcount++ == ctl->batchlimit)
+    if (NUM_NONZERO(ctl->batchlimit) && (ctl->smtp_socket != -1) && ++batchcount == ctl->batchlimit)
     {
-       close(ctl->smtp_socket);
+       SockClose(ctl->smtp_socket);
        ctl->smtp_socket = -1;
        batchcount = 0;
     }
@@ -68,7 +60,7 @@ static int smtp_open(struct query *ctl)
         * HELO name fails (RFC1123 section 5.2.5, paragraph 2).
         *
         * How we compute the true mailhost name to pass to the
-        * listener doesn't affect behavior on RFC1123- violating
+        * listener doesn't affect behavior on RFC1123-violating
         * listeners that check for name match; we're going to lose
         * on those anyway because we can never give them a name
         * that matches the local machine fetchmail is running on.
@@ -92,27 +84,33 @@ static int smtp_open(struct query *ctl)
        for (idp = ctl->smtphunt; idp; idp = idp->next)
        {
            char        *cp, *parsed_host;
-#ifdef INET6 
+#ifdef INET6_ENABLE 
            char        *portnum = SMTP_PORT;
 #else
            int         portnum = SMTP_PORT;
-#endif /* INET6 */
+#endif /* INET6_ENABLE */
 
            xalloca(parsed_host, char *, strlen(idp->id) + 1);
 
            ctl->smtphost = idp->id;  /* remember last host tried. */
+           if(ctl->smtphost[0]=='/')
+               ctl->listener = LMTP_MODE;
 
            strcpy(parsed_host, idp->id);
            if ((cp = strrchr(parsed_host, '/')))
            {
                *cp++ = 0;
-#ifdef INET6 
+#ifdef INET6_ENABLE 
                portnum = cp;
 #else
                portnum = atoi(cp);
-#endif /* INET6 */
+#endif /* INET6_ENABLE */
            }
 
+           if (ctl->smtphost[0]=='/'){
+               if((ctl->smtp_socket = UnixOpen(ctl->smtphost))==-1)
+                   continue;
+           } else
            if ((ctl->smtp_socket = SockOpen(parsed_host,portnum,NULL,
                                             ctl->server.plugout)) == -1)
                continue;
@@ -156,17 +154,16 @@ static int smtp_open(struct query *ctl)
      * enforce this.  Now that we have the actual hostname,
      * compute what we should canonicalize with.
      */
-    ctl->destaddr = ctl->smtpaddress ? ctl->smtpaddress : ( ctl->smtphost ? ctl->smtphost : "localhost");
+    ctl->destaddr = ctl->smtpaddress ? ctl->smtpaddress : ( ctl->smtphost && ctl->smtphost[0] != '/' ? ctl->smtphost : "localhost");
 
     if (outlevel >= O_DEBUG && ctl->smtp_socket != -1)
-       error(0, 0, _("forwarding to %s"), ctl->smtphost);
+       report(stdout, _("forwarding to %s\n"), ctl->smtphost);
 
     return(ctl->smtp_socket);
 }
 
 /* these are shared by open_sink and stuffline */
 static FILE *sinkfp;
-static RETSIGTYPE (*sigchld)(int);
 
 int stuffline(struct query *ctl, char *buf)
 /* ship a line to the given control block's output sink (SMTP server or MDA) */
@@ -201,6 +198,7 @@ int stuffline(struct query *ctl, char *buf)
      * decorated any . lines it sends back up.
      */
     if (*buf == '.')
+    {
        if (ctl->server.base_protocol->delimited)       /* server has already byte-stuffed */
        {
            if (ctl->mda)
@@ -215,6 +213,7 @@ int stuffline(struct query *ctl, char *buf)
            else
                /* leave it alone */;
        }
+    }
 
     /* we may need to strip carriage returns */
     if (ctl->stripcr)
@@ -249,46 +248,244 @@ static void sanitize(char *s)
        *cp = '_';
 }
 
-static int send_bouncemail(struct query *ctl, struct msgblk *msgcopy, 
-               int nerrors, char *errors[])
+static int send_bouncemail(struct query *ctl, struct msgblk *msg,
+                          int userclass, char *message,
+                          int nerrors, char *errors[])
+/* bounce back an error report a la RFC 1892 */
 {
-    char buf[MSGBUFSIZE];
-    int i;
+    char daemon_name[18 + HOSTLEN] = "FETCHMAIL-DAEMON@";
+    char boundary[BUFSIZ], *bounce_to;
+    int sock;
 
-    if (open_warning_by_mail(ctl, msgcopy))
+    /* don't bounce  in reply to undeliverable bounces */
+    if (!msg->return_path[0] || strcmp(msg->return_path, "<>") == 0)
        return(FALSE);
 
-    /* generate an error report a la RFC 1892 */
-    stuff_warning(ctl, "MIME-Version: 1.0");
-    stuff_warning(ctl, "Content-Type: multipart/report report-type=text/plain boundary=\"om-mani-padme-hum\"");
-    stuff_warning(ctl, "Content-Transfer-Encoding: 7bit");
-    stuff_warning(ctl, "");
+    bounce_to = (run.bouncemail ? msg->return_path : run.postmaster);
+
+    SMTP_setmode(SMTP_MODE);
 
+    strcat(daemon_name, fetchmailhost);
+
+    /* we need only SMTP for this purpose */
+    if ((sock = SockOpen("localhost", SMTP_PORT, NULL, NULL)) == -1
+               || SMTP_ok(sock) != SM_OK 
+               || SMTP_helo(sock, "localhost") != SM_OK
+               || SMTP_from(sock, daemon_name, (char *)NULL) != SM_OK
+               || SMTP_rcpt(sock, bounce_to) != SM_OK
+               || SMTP_data(sock) != SM_OK)
+       return(FALSE);
+
+    /* our first duty is to keep the sacred foo counters turning... */
+#ifdef HAVE_SNPRINTF
+    snprintf(boundary, sizeof(boundary),
+#else
+    sprintf(boundary,
+#endif /* HAVE_SNPRINTF */
+           "foo-mani-padme-hum-%d-%d-%ld", 
+           (int)getpid(), (int)getppid(), time((time_t *)NULL));
+
+    if (outlevel >= O_VERBOSE)
+       report(stdout, _("SMTP: (bounce-message body)\n"));
+    else
+       /* this will usually go to sylog... */
+       report(stderr, _("mail from %s bounced to %s\n"),
+              daemon_name, bounce_to);
+
+    /* bouncemail headers */
+    SockPrintf(sock, "Return-Path: <>\r\n");
+    SockPrintf(sock, "From: %s\r\n", daemon_name);
+    SockPrintf(sock, "To: %s\r\n", bounce_to);
+    SockPrintf(sock, "MIME-Version: 1.0\r\n");
+    SockPrintf(sock, "Content-Type: multipart/report; report-type=delivery-status;\r\n\tboundary=\"%s\"\r\n", boundary);
+    SockPrintf(sock, "\r\n");
 
     /* RFC1892 part 1 -- human-readable message */
-    stuff_warning(ctl, "-- om-mani-padme-hum"); 
-    stuff_warning(ctl, "");
+    SockPrintf(sock, "--%s\r\n", boundary); 
+    SockPrintf(sock,"Content-Type: text/plain\r\n");
+    SockPrintf(sock, "\r\n");
+    SockWrite(sock, message, strlen(message));
+    SockPrintf(sock, "\r\n");
+    SockPrintf(sock, "\r\n");
+
+    if (nerrors)
+    {
+       struct idlist   *idp;
+       int             nusers;
+       
+       /* RFC1892 part 2 -- machine-readable responses */
+       SockPrintf(sock, "--%s\r\n", boundary); 
+       SockPrintf(sock,"Content-Type: message/delivery-status\r\n");
+       SockPrintf(sock, "\r\n");
+       SockPrintf(sock, "Reporting-MTA: dns; %s\r\n", fetchmailhost);
 
-    /* RFC1892 part 2 -- machine-readable responses */
-    stuff_warning(ctl, "-- om-mani-padme-hum"); 
-    stuff_warning(ctl,"Content-Type: message/delivery-status");
-    stuff_warning(ctl, "");
-    for (i = 0; i < nerrors; i++)
-       stuff_warning(ctl, errors[i]);
+       nusers = 0;
+       for (idp = msg->recipients; idp; idp = idp->next)
+           if (idp->val.status.mark == userclass)
+           {
+               char    *error;
+               /* Minimum RFC1894 compliance + Diagnostic-Code field */
+               SockPrintf(sock, "\r\n");
+               SockPrintf(sock, "Final-Recipient: rfc822; %s\r\n", idp->id);
+               SockPrintf(sock, "Last-Attempt-Date: %s\r\n", rfc822timestamp());
+               SockPrintf(sock, "Action: failed\r\n");
+
+               if (nerrors == 1)
+                   /* one error applies to all users */
+                   error = errors[0];
+               else if (nerrors > nusers)
+               {
+                   SockPrintf(sock, "Internal error: SMTP error count doesn't match number of recipients.\r\n");
+                   break;
+               }
+               else
+                   /* errors correspond 1-1 to selected users */
+                   error = errors[nusers++];
+               
+               if (strlen(error) > 9 && isdigit(error[4])
+                       && error[5] == '.' && isdigit(error[6])
+                       && error[7] == '.' && isdigit(error[8]))
+                   /* Enhanced status code available, use it */
+                   SockPrintf(sock, "Status: %5.5s\r\n", &(error[4]));
+               else
+                   /* Enhanced status code not available, fake one */
+                   SockPrintf(sock, "Status: %c.0.0\r\n", error[0]);
+               SockPrintf(sock, "Diagnostic-Code: %s\r\n", error);
+           }
+       SockPrintf(sock, "\r\n");
+    }
 
     /* RFC1892 part 3 -- headers of undelivered message */
-    stuff_warning(ctl, "-- om-mani-padme-hum"); 
-    stuff_warning(ctl, "Content-Type: text/rfc822-headers");
-    stuff_warning(ctl, "");
-    stuffline(ctl, msgcopy->headers);
-
-    stuff_warning(ctl, "-- om-mani-padme-hum --"); 
+    SockPrintf(sock, "--%s\r\n", boundary); 
+    SockPrintf(sock, "Content-Type: text/rfc822-headers\r\n");
+    SockPrintf(sock, "\r\n");
+    SockWrite(sock, msg->headers, strlen(msg->headers));
+    SockPrintf(sock, "\r\n");
+    SockPrintf(sock, "--%s--\r\n", boundary); 
+
+    if (SMTP_eom(sock) != SM_OK || SMTP_quit(sock))
+       return(FALSE);
 
-    close_warning_by_mail(ctl, msgcopy);
+    SockClose(sock);
 
     return(TRUE);
 }
 
+static int handle_smtp_report(struct query *ctl, struct msgblk *msg)
+/* handle SMTP errors based on the content of SMTP_response */
+/* return of PS_REFUSED deletes mail from the server; PS_TRANSIENT keeps it */
+{
+    int smtperr = atoi(smtp_response);
+    char *responses[1];
+
+    xalloca(responses[0], char *, strlen(smtp_response)+1);
+    strcpy(responses[0], smtp_response);
+
+    SMTP_rset(ctl->smtp_socket);    /* stay on the safe side */
+
+    if (outlevel >= O_DEBUG)
+       report(stdout, _("Saved error is still %d\n"), smtperr);
+
+    /*
+     * Note: send_bouncemail message strings are not made subject
+     * to gettext translation because (a) they're going to be 
+     * embedded in a text/plain 7bit part, and (b) they're
+     * going to be associated with listener error-response
+     * messages, which are probably in English (none of the
+     * MTAs I know about are internationalized).
+     */
+    if (str_find(&ctl->antispam, smtperr))
+    {
+       /*
+        * SMTP listener explicitly refuses to deliver mail
+        * coming from this address, probably due to an
+        * anti-spam domain exclusion.  Respect this.  Don't
+        * try to ship the message, and don't prevent it from
+        * being deleted.  There's no point in bouncing the
+        * email either since most spammers don't put their
+        * real return email address anywhere in the headers
+        * (unless the user insists with the SET SPAMBOUNCE
+        * config option).
+        *
+        * Default values:
+        *
+        * 571 = sendmail's "unsolicited email refused"
+        * 550 = exim's new antispam response (temporary)
+        * 501 = exim's old antispam response
+        * 554 = Postfix antispam response.
+        *
+        */
+       if (run.spambounce)
+               send_bouncemail(ctl, msg, XMIT_ACCEPT,
+                       "Our spam filter rejected this transaction.\r\n", 
+                       1, responses);
+       return(PS_REFUSED);
+    }
+
+    /*
+     * Suppress error message only if the response specifically 
+     * meant `excluded for policy reasons'.  We *should* see
+     * an error when the return code is less specific.
+     */
+    if (smtperr >= 400)
+       report(stderr, _("%cMTP error: %s\n"), 
+             ctl->listener,
+             responses[0]);
+
+    switch (smtperr)
+    {
+    case 552: /* message exceeds fixed maximum message size */
+       /*
+        * Permanent no-go condition on the
+        * ESMTP server.  Don't try to ship the message, 
+        * and allow it to be deleted.
+        */
+       send_bouncemail(ctl, msg, XMIT_ACCEPT,
+                       "This message was too large (SMTP error 552).\r\n", 
+                       1, responses);
+       return(run.bouncemail ? PS_REFUSED : PS_TRANSIENT);
+  
+    case 553: /* invalid sending domain */
+       /*
+        * These latter days 553 usually means a spammer is trying to
+        * cover his tracks.  We never bouncemail on these, because 
+        * (a) the return address is invalid by definition, and 
+        * (b) we wouldn't want spammers to get confirmation that
+        * this address is live, anyway.
+        */
+       send_bouncemail(ctl, msg, XMIT_ACCEPT,
+                       "Invalid address in MAIL FROM (SMTP error 553).\r\n", 
+                       1, responses);
+       return(PS_REFUSED);
+
+    default:
+       /* bounce non-transient errors back to the sender */
+       if (smtperr >= 500 && smtperr <= 599)
+           if (send_bouncemail(ctl, msg, XMIT_ACCEPT,
+                               "General SMTP/ESMTP error.\r\n", 
+                               1, responses))
+               return(run.bouncemail ? PS_REFUSED : PS_TRANSIENT);
+       /*
+        * We're going to end up here on 4xx errors, like:
+        *
+        * 451: temporarily unable to identify sender (exim)
+        * 452: temporary out-of-queue-space condition on the ESMTP server.
+        *
+        * These are temporary errors.  Don't try to ship the message,
+        * and suppress deletion so it can be retried on a future
+        * retrieval cycle.
+        *
+        * Bouncemail *might* be appropriate here as a delay
+        * notification (note; if we ever add this, we must make
+        * sure the RFC1894 Action field is "delayed" rather thwn
+        * "failed").  But it's not really necessary because
+        * these are not actual failures, we're very likely to be
+        * able to recover on the next cycle.
+        */
+       return(PS_TRANSIENT);
+    }
+}
+
 int open_sink(struct query *ctl, struct msgblk *msg,
              int *good_addresses, int *bad_addresses)
 /* set up sinkfp to be an input sink we can ship a message to */
@@ -313,7 +510,10 @@ int open_sink(struct query *ctl, struct msgblk *msg,
        else if (ctl->mimemsg & MSG_IS_7BIT)
            fputs(" BODY=7BIT", sinkfp);
 
-       fprintf(sinkfp, " SIZE=%ld\r\n", msg->reallen);
+       /* exim's BSMTP processor does not handle SIZE */
+       /* fprintf(sinkfp, " SIZE=%d", msg->reallen); */
+
+       fprintf(sinkfp, "\r\n");
 
        /*
         * RFC 1123 requires that the domain name part of the
@@ -328,12 +528,14 @@ int open_sink(struct query *ctl, struct msgblk *msg,
        for (idp = msg->recipients; idp; idp = idp->next)
            if (idp->val.status.mark == XMIT_ACCEPT)
            {
-               if (strchr(idp->id, '@'))
-                   fprintf(sinkfp,
-                               "RCPT TO: %s\r\n", idp->id);
+               if (ctl->smtpname)
+                   fprintf(sinkfp, "RCPT TO: %s\r\n", ctl->smtpname);
+               else if (strchr(idp->id, '@'))
+                   fprintf(sinkfp,
+                           "RCPT TO: %s\r\n", idp->id);
                else
                    fprintf(sinkfp,
-                               "RCPT TO: %s@%s\r\n", idp->id, ctl->destaddr);
+                           "RCPT TO: %s@%s\r\n", idp->id, ctl->destaddr);
                *good_addresses = 0;
            }
 
@@ -341,11 +543,236 @@ int open_sink(struct query *ctl, struct msgblk *msg,
 
        if (ferror(sinkfp))
        {
-           error(0, -1, _("BSMTP file open or preamble write failed"));
+           report(stderr, _("BSMTP file open or preamble write failed\n"));
            return(PS_BSMTP);
        }
     }
-    else if (ctl->mda)         /* we have a declared MDA */
+
+    /* 
+     * Try to forward to an SMTP or LMTP listener.  If the attempt to 
+     * open a socket fails, fall through to attempt delivery via
+     * local MDA.
+     */
+    else if (!ctl->mda && smtp_open(ctl) != -1)
+    {
+       const char      *ap;
+       char            options[MSGBUFSIZE]; 
+       char            addr[HOSTLEN+USERNAMELEN+1];
+       char            **from_responses;
+       int             total_addresses;
+
+       /*
+        * Compute ESMTP options.
+        */
+       options[0] = '\0';
+       if (ctl->server.esmtp_options & ESMTP_8BITMIME) {
+             if (ctl->pass8bits || (ctl->mimemsg & MSG_IS_8BIT))
+               strcpy(options, " BODY=8BITMIME");
+             else if (ctl->mimemsg & MSG_IS_7BIT)
+               strcpy(options, " BODY=7BIT");
+        }
+
+       if ((ctl->server.esmtp_options & ESMTP_SIZE) && msg->reallen > 0)
+           sprintf(options + strlen(options), " SIZE=%d", msg->reallen);
+
+       /*
+        * Try to get the SMTP listener to take the Return-Path
+        * address as MAIL FROM.  If it won't, fall back on the
+        * remotename and mailserver host.  This won't affect replies,
+        * which use the header From address anyway; the MAIL FROM
+        * address is a place for the SMTP listener to send
+        * bouncemail.  The point is to guarantee a FQDN in the MAIL
+        * FROM line -- some SMTP listeners, like smail, become
+        * unhappy otherwise.
+        *
+        * RFC 1123 requires that the domain name part of the
+        * MAIL FROM address be "canonicalized", that is a
+        * FQDN or MX but not a CNAME.  We'll assume the Return-Path
+        * header is already in this form here (it certainly
+        * is if rewrite is on).  RFC 1123 is silent on whether
+        * a nonexistent hostname part is considered canonical.
+        *
+        * This is a potential problem if the MTAs further upstream
+        * didn't pass canonicalized From/Return-Path lines, *and* the
+        * local SMTP listener insists on them. 
+        */
+       if (!msg->return_path[0])
+       {
+#ifdef HAVE_SNPRINTF
+           snprintf(addr, sizeof(addr),
+#else
+           sprintf(addr,
+#endif /* HAVE_SNPRINTF */
+                 "%s@%s", ctl->remotename, ctl->server.truename);
+           ap = addr;
+       }
+       else if (strchr(msg->return_path, '@'))
+           ap = msg->return_path;
+       else            /* in case Return-Path existed but was local */
+       {
+#ifdef HAVE_SNPRINTF
+           snprintf(addr, sizeof(addr),
+#else
+           sprintf(addr,
+#endif /* HAVE_SNPRINTF */
+                   "%s@%s", msg->return_path, ctl->server.truename);
+           ap = addr;
+       }
+
+       if (SMTP_from(ctl->smtp_socket, ap, options) != SM_OK)
+           return(handle_smtp_report(ctl, msg));
+
+       /*
+        * Now list the recipient addressees
+        */
+       total_addresses = 0;
+       for (idp = msg->recipients; idp; idp = idp->next)
+           total_addresses++;
+       xalloca(from_responses, char **, sizeof(char *) * total_addresses);
+       for (idp = msg->recipients; idp; idp = idp->next)
+           if (idp->val.status.mark == XMIT_ACCEPT)
+           {
+               if (strchr(idp->id, '@'))
+                   strcpy(addr, idp->id);
+               else {
+                   if (ctl->smtpname) {
+#ifdef HAVE_SNPRINTF
+                       snprintf(addr, sizeof(addr)-1, "%s", ctl->smtpname);
+#else
+                       sprintf(addr, "%s", ctl->smtpname);
+#endif /* HAVE_SNPRINTF */
+
+                   } else {
+#ifdef HAVE_SNPRINTF
+                     snprintf(addr, sizeof(addr)-1, "%s@%s", idp->id, ctl->destaddr);
+#else
+                     sprintf(addr, "%s@%s", idp->id, ctl->destaddr);
+#endif /* HAVE_SNPRINTF */
+                   }
+               }
+               if (SMTP_rcpt(ctl->smtp_socket, addr) == SM_OK)
+                   (*good_addresses)++;
+               else
+               {
+                   char        errbuf[POPBUFSIZE];
+
+#ifdef __UNUSED__
+                   /*
+                    * I don't remember how this got in here, but it doesn't
+                    * work.  The obvious symptom is that no bounce message
+                    * is sent for a nonexistent user.  Less obviously
+                    * Forwarding to postmaster also does not work. The body is
+                    * discarded.
+                    *
+                    * If a mail is sent to one valid and one invalid
+                    * user, the mail does not go to the valid user
+                    * also as the body is discarded after calling
+                    * RSET!
+                    */
+                   int res;
+                   if ((res = handle_smtp_report(ctl, msg))==PS_REFUSED)
+                       return(PS_REFUSED);
+#endif /* __UNUSED__ */
+
+#ifdef HAVE_SNPRINTF
+                   snprintf(errbuf, sizeof(errbuf), "%s: %s",
+                                   idp->id, smtp_response);
+#else
+                   strncpy(errbuf, idp->id, sizeof(errbuf));
+                   strcat(errbuf, ": ");
+                   strcat(errbuf, smtp_response);
+#endif /* HAVE_SNPRINTF */
+
+                   xalloca(from_responses[*bad_addresses], 
+                           char *, 
+                           strlen(errbuf)+1);
+                   strcpy(from_responses[*bad_addresses], errbuf);
+
+                   (*bad_addresses)++;
+                   idp->val.status.mark = XMIT_RCPTBAD;
+                   if (outlevel >= O_VERBOSE)
+                       report(stderr, 
+                             _("%cMTP listener doesn't like recipient address `%s'\n"),
+                             ctl->listener, addr);
+               }
+           }
+       if (*bad_addresses)
+           send_bouncemail(ctl, msg, XMIT_RCPTBAD,
+                            "Some addresses were rejected by the MDA fetchmail forwards to.\r\n",
+                            *bad_addresses, from_responses);
+       /*
+        * It's tempting to do local notification only if bouncemail was
+        * insufficient -- that is, to add && total_addresses > *bad_addresses
+        * to the test here.  The problem with this theory is that it would
+        * make initial diagnosis of a broken multidrop configuration very
+        * hard -- most single-recipient messages would just invisibly bounce.
+        */
+       if (!(*good_addresses)) 
+       {
+           if (strchr(run.postmaster, '@'))
+               strncpy(addr, run.postmaster, sizeof(addr));
+           else
+           {
+#ifdef HAVE_SNPRINTF
+               snprintf(addr, sizeof(addr)-1, "%s@%s", run.postmaster, ctl->destaddr);
+#else
+               sprintf(addr, "%s@%s", run.postmaster, ctl->destaddr);
+#endif /* HAVE_SNPRINTF */
+           }
+
+           if (SMTP_rcpt(ctl->smtp_socket, addr) != SM_OK)
+           {
+               report(stderr, _("can't even send to %s!\n"), run.postmaster);
+               SMTP_rset(ctl->smtp_socket);    /* required by RFC1870 */
+               return(PS_SMTP);
+           }
+
+           if (outlevel >= O_VERBOSE)
+               report(stderr, _("no address matches; forwarding to %s.\n"), run.postmaster);
+       }
+
+       /* 
+        * Tell the listener we're ready to send data.
+        * Some listeners (like zmailer) may return antispam errors here.
+        */
+       if (SMTP_data(ctl->smtp_socket) != SM_OK)
+           return(handle_smtp_report(ctl, msg));
+    }
+
+    /*
+     * Awkward case.  User didn't specify an MDA.  Our attempt to get a
+     * listener socket failed.  Try to cope anyway -- initial configuration
+     * may have found procmail.
+     */
+    else if (!ctl->mda)
+    {
+       report(stderr, _("%cMTP connect to %s failed\n"),
+              ctl->listener,
+              ctl->smtphost ? ctl->smtphost : "localhost");
+
+#ifndef FALLBACK_MDA
+       /* No fallback MDA declared.  Bail out. */
+       return(PS_SMTP);
+#else
+       /*
+        * If user had things set up to forward offsite, no way
+        * we want to deliver locally!
+        */
+       if (ctl->smtphost && strcmp(ctl->smtphost, "localhost"))
+           return(PS_SMTP);
+
+       /* 
+        * User was delivering locally.  We have a fallback MDA.
+        * Latch it in place, logging the error, and fall through.
+        */
+       ctl->mda = FALLBACK_MDA;
+
+       report(stderr, _("can't raise the listener; falling back to %s"),
+                        FALLBACK_MDA);
+#endif
+    }
+
+    if (ctl->mda)              /* must deliver through an MDA */
     {
        int     length = 0, fromlen = 0, nameslen = 0;
        char    *names = NULL, *before, *after, *from = NULL;
@@ -462,7 +889,7 @@ int open_sink(struct query *ctl, struct msgblk *msg,
 
 
        if (outlevel >= O_DEBUG)
-           error(0, 0, _("about to deliver with: %s"), before);
+           report(stdout, _("about to deliver with: %s\n"), before);
 
 #ifdef HAVE_SETEUID
        /*
@@ -485,191 +912,16 @@ int open_sink(struct query *ctl, struct msgblk *msg,
 
        if (!sinkfp)
        {
-           error(0, 0, _("MDA open failed"));
+           report(stderr, _("MDA open failed\n"));
            return(PS_IOERR);
        }
-
-       sigchld = signal(SIGCHLD, SIG_DFL);
-    }
-    else /* forward to an SMTP or LMTP listener */
-    {
-       const char      *ap;
-       char    options[MSGBUFSIZE], addr[128];
-
-       /* build a connection to the SMTP listener */
-       if ((smtp_open(ctl) == -1))
-       {
-           error(0, errno, _("%cMTP connect to %s failed"),
-                 ctl->listener,
-                 ctl->smtphost ? ctl->smtphost : "localhost");
-           return(PS_SMTP);
-       }
-
-       /*
-        * Compute ESMTP options.
-        */
-       options[0] = '\0';
-       if (ctl->server.esmtp_options & ESMTP_8BITMIME) {
-             if (ctl->pass8bits || (ctl->mimemsg & MSG_IS_8BIT))
-               strcpy(options, " BODY=8BITMIME");
-             else if (ctl->mimemsg & MSG_IS_7BIT)
-               strcpy(options, " BODY=7BIT");
-        }
-
-       if ((ctl->server.esmtp_options & ESMTP_SIZE) && msg->reallen > 0)
-           sprintf(options + strlen(options), " SIZE=%ld", msg->reallen);
-
-       /*
-        * Try to get the SMTP listener to take the Return-Path
-        * address as MAIL FROM .  If it won't, fall back on the
-        * calling-user ID.  This won't affect replies, which use the
-        * header From address anyway.
-        *
-        * RFC 1123 requires that the domain name part of the
-        * MAIL FROM address be "canonicalized", that is a
-        * FQDN or MX but not a CNAME.  We'll assume the From
-        * header is already in this form here (it certainly
-        * is if rewrite is on).  RFC 1123 is silent on whether
-        * a nonexistent hostname part is considered canonical.
-        *
-        * This is a potential problem if the MTAs further upstream
-        * didn't pass canonicalized From/Return-Path lines, *and* the
-        * local SMTP listener insists on them.
-        *
-        * None of these error conditions generates bouncemail.  Comments
-        * below explain for each case why this is so.
-        */
-       ap = (msg->return_path[0]) ? msg->return_path : user;
-       if (SMTP_from(ctl->smtp_socket, ap, options) != SM_OK)
-       {
-           int smtperr = atoi(smtp_response);
-
-           if (str_find(&ctl->antispam, smtperr))
-           {
-               /*
-                * SMTP listener explicitly refuses to deliver mail
-                * coming from this address, probably due to an
-                * anti-spam domain exclusion.  Respect this.  Don't
-                * try to ship the message, and don't prevent it from
-                * being deleted.  Typical values:
-                *
-                * 501 = exim's old antispam response
-                * 550 = exim's new antispam response (temporary)
-                * 553 = sendmail 8.8.7's generic REJECT 
-                * 571 = sendmail's "unsolicited email refused"
-                *
-                * We don't send bouncemail on antispam failures because
-                * we don't want the scumbags to know the address is even
-                * valid.
-                */
-               SMTP_rset(ctl->smtp_socket);    /* required by RFC1870 */
-               return(PS_REFUSED);
-           }
-
-           /*
-            * Suppress error message only if the response specifically 
-            * meant `excluded for policy reasons'.  We *should* see
-            * an error when the return code is less specific.
-            */
-           if (smtperr >= 400)
-               error(0, -1, _("%cMTP error: %s"), 
-                     ctl->listener,
-                     smtp_response);
-
-           switch (smtperr)
-           {
-           case 452: /* insufficient system storage */
-               /*
-                * Temporary out-of-queue-space condition on the
-                * ESMTP server.  Don't try to ship the message, 
-                * and suppress deletion so it can be retried on
-                * a future retrieval cycle. 
-                *
-                * Bouncemail *might* be appropriate here as a delay
-                * notification.  But it's not really necessary because
-                * this is not an actual failure, we're very likely to be
-                * able to recover on the next cycle.
-                */
-               SMTP_rset(ctl->smtp_socket);    /* required by RFC1870 */
-               return(PS_TRANSIENT);
-
-           case 552: /* message exceeds fixed maximum message size */
-           case 553: /* invalid sending domain */
-               /*
-                * Permanent no-go condition on the
-                * ESMTP server.  Don't try to ship the message, 
-                * and allow it to be deleted.
-                *
-                * Bouncemail would be appropriate for 552, but in these 
-                * latter days 553 usually means a spammer is trying to
-                * cover his tracks.  We'd rather deny the scumbags any
-                * feedback that the address is valid.
-                */
-               SMTP_rset(ctl->smtp_socket);    /* required by RFC1870 */
-               return(PS_REFUSED);
-
-           default:    /* retry with postmaster's address */
-               if (SMTP_from(ctl->smtp_socket,run.postmaster,options)!=SM_OK)
-               {
-                   error(0, -1, _("%cMTP error: %s"),
-                         ctl->listener,
-                         smtp_response);
-                   return(PS_SMTP);    /* should never happen */
-               }
-           }
-       }
-
-       /*
-        * Now list the recipient addressees
-        */
-       for (idp = msg->recipients; idp; idp = idp->next)
-           if (idp->val.status.mark == XMIT_ACCEPT)
-           {
-               if (strchr(idp->id, '@'))
-                   strcpy(addr, idp->id);
-               else
-#ifdef HAVE_SNPRINTF
-                   snprintf(addr, sizeof(addr)-1, "%s@%s", idp->id, ctl->destaddr);
-#else
-                   sprintf(addr, "%s@%s", idp->id, ctl->destaddr);
-#endif /* HAVE_SNPRINTF */
-
-               if (SMTP_rcpt(ctl->smtp_socket, addr) == SM_OK)
-                   (*good_addresses)++;
-               else
-               {
-                   (*bad_addresses)++;
-                   idp->val.status.mark = XMIT_ANTISPAM;
-                   error(0, 0, 
-                         _("%cMTP listener doesn't like recipient address `%s'"),
-                         ctl->listener, addr);
-               }
-           }
-       if (!(*good_addresses))
-       {
-#ifdef HAVE_SNPRINTF
-           snprintf(addr, sizeof(addr)-1, "%s@%s", run.postmaster, ctl->destaddr);
-#else
-           sprintf(addr, "%s@%s", run.postmaster, ctl->destaddr);
-#endif /* HAVE_SNPRINTF */
-
-           if (SMTP_rcpt(ctl->smtp_socket, addr) != SM_OK)
-           {
-               error(0, 0, _("can't even send to %s!"), run.postmaster);
-               SMTP_rset(ctl->smtp_socket);    /* required by RFC1870 */
-               return(PS_SMTP);
-           }
-       }
-
-       /* tell it we're ready to send data */
-       SMTP_data(ctl->smtp_socket);
     }
 
     /*
      * We need to stash this away in order to know how many
      * response lines to expect after the LMTP end-of-message.
      */
-    msg->lmtp_responses = *good_addresses;
+    lmtp_responses = *good_addresses;
 
     return(PS_SUCCESS);
 }
@@ -677,7 +929,7 @@ int open_sink(struct query *ctl, struct msgblk *msg,
 void release_sink(struct query *ctl)
 /* release the per-message output sink, whether it's a pipe or SMTP socket */
 {
-    if (ctl->bsmtp)
+    if (ctl->bsmtp && sinkfp)
        fclose(sinkfp);
     else if (ctl->mda)
     {
@@ -686,7 +938,6 @@ void release_sink(struct query *ctl)
            pclose(sinkfp);
            sinkfp = (FILE *)NULL;
        }
-       signal(SIGCHLD, sigchld);
     }
 }
 
@@ -705,22 +956,26 @@ int close_sink(struct query *ctl, struct msgblk *msg, flag forward)
        }
        else
            rc = 0;
-       signal(SIGCHLD, sigchld);
        if (rc)
        {
-           error(0, -1, _("MDA exited abnormally or returned nonzero status"));
+           report(stderr, 
+                  _("MDA exited abnormally or returned nonzero status\n"));
            return(FALSE);
        }
     }
-    else if (ctl->bsmtp)
+    else if (ctl->bsmtp && sinkfp)
     {
+       int error;
+
        /* implicit disk-full check here... */
-       fputs("..\r\n", sinkfp);
+       fputs(".\r\n", sinkfp);
+       error = ferror(sinkfp);
        if (strcmp(ctl->bsmtp, "-"))
-           fclose(sinkfp);
-       if (ferror(sinkfp))
+           if (fclose(sinkfp) == EOF) error = 1;
+       if (error)
        {
-           error(0, -1, _("Message termination or close of BSMTP file failed"));
+           report(stderr, 
+                  _("Message termination or close of BSMTP file failed\n"));
            return(FALSE);
        }
     }
@@ -729,8 +984,13 @@ int close_sink(struct query *ctl, struct msgblk *msg, flag forward)
        /* write message terminator */
        if (SMTP_eom(ctl->smtp_socket) != SM_OK)
        {
-           error(0, -1, _("SMTP listener refused delivery"));
-           return(FALSE);
+           if (handle_smtp_report(ctl, msg) != PS_REFUSED)
+               return(FALSE);
+           else
+           {
+               report(stderr, _("SMTP listener refused delivery\n"));
+               return(TRUE);
+           }
        }
 
        /*
@@ -744,7 +1004,8 @@ int close_sink(struct query *ctl, struct msgblk *msg, flag forward)
         * to people who got it the first time.
         */
        if (ctl->listener == LMTP_MODE)
-           if (msg->lmtp_responses == 0)
+       {
+           if (lmtp_responses == 0)
            {
                SMTP_ok(ctl->smtp_socket); 
 
@@ -756,10 +1017,10 @@ int close_sink(struct query *ctl, struct msgblk *msg, flag forward)
                 * comply.
                 */
                if (atoi(smtp_response) == 503)
-                   error(0, -1, _("LMTP delivery error on EOM"));
+                   report(stderr, _("LMTP delivery error on EOM\n"));
                else
-                   error(0, -1,
-                         _("Unexpected non-503 response to LMTP EOM: %s"),
+                   report(stderr,
+                         _("Unexpected non-503 response to LMTP EOM: %s\n"),
                          smtp_response);
 
                /*
@@ -776,8 +1037,8 @@ int close_sink(struct query *ctl, struct msgblk *msg, flag forward)
                char    **responses;
 
                /* eat the RFC2033-required responses, saving errors */ 
-               xalloca(responses, char **, sizeof(char *) * msg->lmtp_responses);
-               for (errors = i = 0; i < msg->lmtp_responses; i++)
+               xalloca(responses, char **, sizeof(char *) * lmtp_responses);
+               for (errors = i = 0; i < lmtp_responses; i++)
                {
                    if (SMTP_ok(ctl->smtp_socket) == SM_OK)
                        responses[i] = (char *)NULL;
@@ -793,44 +1054,20 @@ int close_sink(struct query *ctl, struct msgblk *msg, flag forward)
 
                if (errors == 0)
                    return(TRUE);       /* all deliveries succeeded */
-               else if (errors == msg->lmtp_responses)
-                   return(FALSE);      /* all deliveries failed */
                else
-               {
                    /*
-                    * Now life gets messy.  There are multiple recipients,
-                    * and one or more (but not all) deliveries failed.
-                    *
-                    * What we'd really like to do is bounce a
-                    * failures list back to the sender and return
-                    * TRUE, deleting the message from the server so
-                    * it won't be re-forwarded on subsequent poll
-                    * cycles.
-                    *
-                    * We can't do that yet, so instead we report 
-                    * failures to the calling-user/postmaster.  If we can't,
-                    * there's a transient error in local delivery; leave
-                    * the message on the server.
+                    * One or more deliveries failed.
+                    * If we can bounce a failures list back to the
+                    * sender, and the postmaster does not want to
+                    * deal with the bounces return TRUE, deleting the
+                    * message from the server so it won't be
+                    * re-forwarded on subsequent poll cycles.
                     */
-                   send_bouncemail(ctl,
-                                   (struct msgblk *)NULL,
-                                   errors, responses);
-
-                   /*
-                    * It's not completely clear what to do here,
-                    * either.  We choose to interpret delivery
-                    * failure here as a permanent error, so the
-                    * people who got successful deliveries won't see
-                    * endless repetitions of the same message on
-                    * subsequent poll messages.  If we're wrong, a
-                    * transient error will cause someone to lose
-                    * mail.  This could only happen with
-                    * multi-recipient messages coming from a remote
-                    * mailserver to two or more local users...
-                    */
-                   return(TRUE);
-               }
+                 return(send_bouncemail(ctl, msg, XMIT_ACCEPT,
+                                        "LSMTP partial delivery failure.\r\n",
+                                        errors, responses));
            }
+       }
     }
 
     return(TRUE);
@@ -843,42 +1080,32 @@ int open_warning_by_mail(struct query *ctl, struct msgblk *msg)
 
     /*
      * Dispatching warning email is a little complicated.  The problem is
-     * that we have to deal with four distinct cases:
+     * that we have to deal with three distinct cases:
      *
-     * 1. Non-null msg argument.  We're trying to generate bouncemail
-     * about the given message.  Address using the Return-Path member.
-     *
-     * 2. Single-drop running from user account.  Warning mail should
+     * 1. Single-drop running from user account.  Warning mail should
      * go to the local name for which we're collecting (coincides
      * with calling user).
      *
-     * 3. Single-drop running from root or other privileged ID, with rc
+     * 2. Single-drop running from root or other privileged ID, with rc
      * file generated on the fly (Ken Estes's weird setup...)  Mail
      * should go to the local name for which we're collecting (does not 
      * coincide with calling user).
      * 
-     * 4. Multidrop.  Mail must go to postmaster.  We leave the recipients
+     * 3. Multidrop.  Mail must go to postmaster.  We leave the recipients
      * member null so this message will fall through to run.postmaster.
      *
      * The zero in the reallen element means we won't pass a SIZE
      * option to ESMTP; the message length would be more trouble than
      * it's worth to compute.
      */
-    struct msgblk reply = {NULL, NULL, "FETCHMAIL-DAEMON", 0};
-    int status;
+    struct msgblk reply = {NULL, NULL, "FETCHMAIL-DAEMON@", 0};
 
-    if (msg)                           /* send bouncemail (not used yet) */
-    {
-       if (!msg->return_path[0])
-           return(PS_REFUSED);
-       
-       save_str(&reply.recipients, msg->return_path, XMIT_ACCEPT);
-       status = open_sink(ctl, &reply, &good, &bad);
-       free_str_list(&reply.recipients);
-       return(status);
-    }
-    else if (!MULTIDROP(ctl))          /* send to calling user */
+    strcat(reply.return_path, fetchmailhost);
+
+    if (!MULTIDROP(ctl))               /* send to calling user */
     {
+       int status;
+
        save_str(&reply.recipients, ctl->localnames->id, XMIT_ACCEPT);
        status = open_sink(ctl, &reply, &good, &bad);
        free_str_list(&reply.recipients);
@@ -919,7 +1146,11 @@ va_dcl
 #endif
     va_end(ap);
 
+#ifdef HAVE_SNPRINTF
+    snprintf(buf+strlen(buf), sizeof(buf)-strlen(buf), "\r\n");
+#else
     strcat(buf, "\r\n");
+#endif /* HAVE_SNPRINTF */
 
     stuffline(ctl, buf);
 }
@@ -927,7 +1158,7 @@ va_dcl
 void close_warning_by_mail(struct query *ctl, struct msgblk *msg)
 /* sign and send mailed warnings */
 {
-    stuff_warning(ctl, "--\r\n\t\t\t\tThe Fetchmail Daemon\r\n");
+    stuff_warning(ctl, _("--\r\n\t\t\t\tThe Fetchmail Daemon\r\n"));
     close_sink(ctl, msg, TRUE);
 }