]> Pileus Git - ~andy/fetchmail/blobdiff - sink.c
Added warning to differs.
[~andy/fetchmail] / sink.c
diff --git a/sink.c b/sink.c
index 7146b21411b429cf25f30f6b3841667d92ba9fe6..e3cb4a8fc21e4e2bade12f005b21e0b0c54c4043 100644 (file)
--- a/sink.c
+++ b/sink.c
@@ -15,6 +15,7 @@
 #include  <errno.h>
 #include  <string.h>
 #include  <signal.h>
+#include  <time.h>
 #ifdef HAVE_MEMORY_H
 #include  <memory.h>
 #endif /* HAVE_MEMORY_H */
 #else
 #include  <varargs.h>
 #endif
+#include  <ctype.h>
 
 #include  "fetchmail.h"
 #include  "socket.h"
 #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
 
-static int lmtp_responses;     /* how many should we expect? */
-static struct msgblk msgcopy;  /* copies of various message internals */
+/* makes the open_sink()/close_sink() pair non-reentrant */
+static int lmtp_responses;
 
 static 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);
        ctl->smtp_socket = -1;
@@ -92,11 +95,11 @@ 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);
 
@@ -106,11 +109,11 @@ static int smtp_open(struct query *ctl)
            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->smtp_socket = SockOpen(parsed_host,portnum,NULL,
@@ -159,7 +162,7 @@ static int smtp_open(struct query *ctl)
     ctl->destaddr = ctl->smtpaddress ? ctl->smtpaddress : ( ctl->smtphost ? 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);
 }
@@ -201,6 +204,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 +219,7 @@ int stuffline(struct query *ctl, char *buf)
            else
                /* leave it alone */;
        }
+    }
 
     /* we may need to strip carriage returns */
     if (ctl->stripcr)
@@ -249,6 +254,228 @@ static void sanitize(char *s)
        *cp = '_';
 }
 
+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 daemon_name[18 + HOSTLEN] = "FETCHMAIL-DAEMON@";
+    char boundary[BUFSIZ], *ts, *bounce_to;
+    int sock;
+
+    /* don't bounce  in reply to undeliverable bounces */
+    if (!msg->return_path[0] || strcmp(msg->return_path, "<>") == 0)
+       return(FALSE);
+
+    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);
+
+    sprintf(boundary, 
+           "om-mani-padme-hum-%d-%d-%ld", 
+           (int)getpid(), (int)getppid(), time((time_t *)NULL));
+
+    ts = rfc822timestamp();
+
+    if (outlevel >= O_VERBOSE)
+       report(stdout, "SMTP: (bounce-message body)\n");
+
+    /* 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 */
+    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);
+
+       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", ts);
+               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 */
+    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);
+
+    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 */
+/* Mail is deleted from the server if this function returns PS_REFUSED. */
+{
+    int smtperr = atoi(smtp_response);
+    char *responses[1];
+
+    xalloca(responses[0], char *, strlen(smtp_response)+1);
+    strcpy(responses[0], smtp_response);
+
+    /*
+     * 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.  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.
+        *
+        */
+       SMTP_rset(ctl->smtp_socket);    /* stay on the safe site */
+       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,
+             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 (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
+        * 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 */
+       /*
+        * Permanent no-go condition on the
+        * ESMTP server.  Don't try to ship the message, 
+        * and allow it to be deleted.
+        */
+       SMTP_rset(ctl->smtp_socket);    /* required by RFC1870 */
+       send_bouncemail(ctl, msg, XMIT_ACCEPT,
+                       "This message was too large.\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.
+        */
+       SMTP_rset(ctl->smtp_socket);    /* stay on the safe side */
+       send_bouncemail(ctl, msg, XMIT_ACCEPT,
+                       "Invalid address.\r\n", 
+                       1, responses);
+       return(PS_REFUSED);
+
+    default:   /* bounce non-transient errors back to the sender */
+       SMTP_rset(ctl->smtp_socket);    /* stay on the safe side */
+       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);
+       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 */
@@ -273,7 +500,7 @@ 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);
+       fprintf(sinkfp, " SIZE=%d\r\n", msg->reallen);
 
        /*
         * RFC 1123 requires that the domain name part of the
@@ -301,7 +528,7 @@ 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);
        }
     }
@@ -422,7 +649,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
        /*
@@ -445,32 +672,29 @@ 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 listener */
+    else /* forward to an SMTP or LMTP listener */
     {
        const char      *ap;
-       char    options[MSGBUFSIZE], addr[128];
+       char            options[MSGBUFSIZE]; 
+       char            addr[HOSTLEN+USERNAMELEN+1];
+       char            **from_responses;
+       int             total_addresses;
 
        /* build a connection to the SMTP listener */
        if ((smtp_open(ctl) == -1))
        {
-           error(0, errno, "%cMTP connect to %s failed",
+           report(stderr, _("%cMTP connect to %s failed\n"),
                  ctl->listener,
                  ctl->smtphost ? ctl->smtphost : "localhost");
            return(PS_SMTP);
        }
 
-       /*
-        * Stash a copy of the parsed message block 
-        * for use by close_sink().
-        */
-       memcpy(&msgcopy, msg, sizeof(struct msgblk));
-
        /*
         * Compute ESMTP options.
         */
@@ -483,7 +707,7 @@ int open_sink(struct query *ctl, struct msgblk *msg,
         }
 
        if ((ctl->server.esmtp_options & ESMTP_SIZE) && msg->reallen > 0)
-           sprintf(options + strlen(options), " SIZE=%ld", msg->reallen);
+           sprintf(options + strlen(options), " SIZE=%d", msg->reallen);
 
        /*
         * Try to get the SMTP listener to take the Return-Path
@@ -501,93 +725,18 @@ int open_sink(struct query *ctl, struct msgblk *msg,
         * 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 */
-               }
-           }
-       }
+           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)
            {
@@ -604,31 +753,66 @@ int open_sink(struct query *ctl, struct msgblk *msg,
                    (*good_addresses)++;
                else
                {
+                   char        errbuf[POPBUFSIZE];
+
+                   strcpy(errbuf, idp->id);
+                   strcat(errbuf, ": ");
+                   strcat(errbuf, smtp_response);
+
+                   xalloca(from_responses[*bad_addresses], 
+                           char *, 
+                           strlen(errbuf)+1);
+                   strcpy(from_responses[*bad_addresses], errbuf);
+
                    (*bad_addresses)++;
-                   idp->val.status.mark = XMIT_ANTISPAM;
-                   error(0, 0, 
-                         "%cMTP listener doesn't like recipient address `%s'",
-                         ctl->listener, addr);
+                   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 (!(*good_addresses))
+       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, '@'))
+               strcpy(addr, run.postmaster);
+           else
+           {
 #ifdef HAVE_SNPRINTF
-           snprintf(addr, sizeof(addr)-1, "%s@%s", run.postmaster, ctl->destaddr);
+               snprintf(addr, sizeof(addr)-1, "%s@%s", run.postmaster, ctl->destaddr);
 #else
-           sprintf(addr, "%s@%s", run.postmaster, ctl->destaddr);
+               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);
+               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 it we're ready to send data */
-       SMTP_data(ctl->smtp_socket);
+       /* 
+        * 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));
     }
 
     /*
@@ -656,7 +840,7 @@ void release_sink(struct query *ctl)
     }
 }
 
-int close_sink(struct query *ctl, flag forward)
+int close_sink(struct query *ctl, struct msgblk *msg, flag forward)
 /* perform end-of-message actions on the current output sink */
 {
     if (ctl->mda)
@@ -674,7 +858,8 @@ int close_sink(struct query *ctl, flag forward)
        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);
        }
     }
@@ -686,7 +871,8 @@ int close_sink(struct query *ctl, flag forward)
            fclose(sinkfp);
        if (ferror(sinkfp))
        {
-           error(0, -1, "Message termination or close of BSMTP file failed");
+           report(stderr, 
+                  _("Message termination or close of BSMTP file failed\n"));
            return(FALSE);
        }
     }
@@ -695,8 +881,13 @@ int close_sink(struct query *ctl, 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);
+           }
        }
 
        /*
@@ -710,6 +901,7 @@ int close_sink(struct query *ctl, flag forward)
         * to people who got it the first time.
         */
        if (ctl->listener == LMTP_MODE)
+       {
            if (lmtp_responses == 0)
            {
                SMTP_ok(ctl->smtp_socket); 
@@ -722,10 +914,10 @@ int close_sink(struct query *ctl, 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);
 
                /*
@@ -759,92 +951,65 @@ int close_sink(struct query *ctl, flag forward)
 
                if (errors == 0)
                    return(TRUE);       /* all deliveries succeeded */
-               else if (errors == 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.
-                    */
-                   char buf[MSGBUFSIZE];
-
-                   if (open_warning_by_mail(ctl))
-                       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, "");
-
-
-                   /* RFC1892 part 1 -- human-readable message */
-                   stuff_warning(ctl, "-- om-mani-padme-hum"); 
-                   stuff_warning(ctl, "");
-
-                   /* 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 < errors; i++)
-                       stuff_warning(ctl, responses[i]);
-
-                   /* 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 --"); 
-
-                   close_warning_by_mail(ctl);
-
                    /*
-                    * 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...
+                    * 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.
                     */
-                   return(TRUE);
-               }
+                 return(send_bouncemail(ctl, msg, XMIT_ACCEPT,
+                                        "LSMTP partial delivery failure.\r\n",
+                                        errors, responses));
            }
+       }
     }
 
     return(TRUE);
 }
 
-int open_warning_by_mail(struct query *ctl)
+int open_warning_by_mail(struct query *ctl, struct msgblk *msg)
 /* set up output sink for a mailed warning to calling user */
 {
     int        good, bad;
 
     /*
-     * We give a null address list as the recipients member because we
-     * actually *want* this message to go to run.postmaster.  The zero
-     * length arg 5 means we won't pass a SIZE option to ESMTP; the
-     * message length would be more trouble than it's worth to compute.
+     * Dispatching warning email is a little complicated.  The problem is
+     * that we have to deal with three distinct cases:
+     *
+     * 1. Single-drop running from user account.  Warning mail should
+     * go to the local name for which we're collecting (coincides
+     * with calling user).
+     *
+     * 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).
+     * 
+     * 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.
      */
-    static struct msgblk msg = {NULL, NULL, "FETCHMAIL-DAEMON", 0};
+    struct msgblk reply = {NULL, NULL, "FETCHMAIL-DAEMON@", 0};
+
+    strcat(reply.return_path, fetchmailhost);
 
-    return(open_sink(ctl, &msg, &good, &bad));
+    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);
+       return(status);
+    }
+    else                               /* send to postmaster  */
+       return(open_sink(ctl, &reply, &good, &bad));
 }
 
 #if defined(HAVE_STDARG_H)
@@ -883,11 +1048,11 @@ va_dcl
     stuffline(ctl, buf);
 }
 
-void close_warning_by_mail(struct query *ctl)
+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");
-    close_sink(ctl, TRUE);
+    close_sink(ctl, msg, TRUE);
 }
 
 /* sink.c ends here */