don't alias \-quoted addresses
[unix-history] / usr / src / usr.sbin / sendmail / src / recipient.c
index 5b412fc..af46314 100644 (file)
@@ -1,5 +1,5 @@
 /*
 /*
- * Copyright (c) 1983 Eric P. Allman
+ * Copyright (c) 1983, 1995 Eric P. Allman
  * Copyright (c) 1988, 1993
  *     The Regents of the University of California.  All rights reserved.
  *
  * Copyright (c) 1988, 1993
  *     The Regents of the University of California.  All rights reserved.
  *
@@ -7,11 +7,10 @@
  */
 
 #ifndef lint
  */
 
 #ifndef lint
-static char sccsid[] = "@(#)recipient.c        8.49 (Berkeley) %G%";
+static char sccsid[] = "@(#)recipient.c        8.96 (Berkeley) %G%";
 #endif /* not lint */
 
 # include "sendmail.h"
 #endif /* not lint */
 
 # include "sendmail.h"
-# include <pwd.h>
 
 /*
 **  SENDTOLIST -- Designate a send list.
 
 /*
 **  SENDTOLIST -- Designate a send list.
@@ -33,6 +32,8 @@ static char sccsid[] = "@(#)recipient.c       8.49 (Berkeley) %G%";
 **                     expansion.
 **             sendq -- a pointer to the head of a queue to put
 **                     these people into.
 **                     expansion.
 **             sendq -- a pointer to the head of a queue to put
 **                     these people into.
+**             aliaslevel -- the current alias nesting depth -- to
+**                     diagnose loops.
 **             e -- the envelope in which to add these recipients.
 **             qflags -- special flags to set in the q_flags field.
 **
 **             e -- the envelope in which to add these recipients.
 **             qflags -- special flags to set in the q_flags field.
 **
@@ -43,13 +44,18 @@ static char sccsid[] = "@(#)recipient.c     8.49 (Berkeley) %G%";
 **             none.
 */
 
 **             none.
 */
 
-# define MAXRCRSN      10
+#define MAXRCRSN       10      /* maximum levels of alias recursion */
 
 
+/* q_flags bits inherited from ctladdr */
+#define QINHERITEDBITS (QPINGONSUCCESS|QPINGONFAILURE|QPINGONDELAY|QHASNOTIFY)
+
+int
 ADDRESS *
 sendto(list, copyf, ctladdr, qflags)
        char *list;
        ADDRESS *ctladdr;
        ADDRESS **sendq;
 ADDRESS *
 sendto(list, copyf, ctladdr, qflags)
        char *list;
        ADDRESS *ctladdr;
        ADDRESS **sendq;
+       int aliaslevel;
        register ENVELOPE *e;
        u_short qflags;
 {
        register ENVELOPE *e;
        u_short qflags;
 {
@@ -58,7 +64,10 @@ sendto(list, copyf, ctladdr, qflags)
        bool firstone;          /* set on first address sent */
        char delimiter;         /* the address delimiter */
        int naddrs;
        bool firstone;          /* set on first address sent */
        char delimiter;         /* the address delimiter */
        int naddrs;
+       int i;
        char *oldto = e->e_to;
        char *oldto = e->e_to;
+       char *bufp;
+       char buf[MAXNAME + 1];
        ADDRESS *sibl;          /* sibling pointer in tree */
        ADDRESS *prev;          /* previous sibling */
 
        ADDRESS *sibl;          /* sibling pointer in tree */
        ADDRESS *prev;          /* previous sibling */
 
@@ -87,7 +96,15 @@ sendto(list, copyf, ctladdr, qflags)
        al = NULL;
        naddrs = 0;
 
        al = NULL;
        naddrs = 0;
 
-       for (p = list; *p != '\0'; )
+       /* make sure we have enough space to copy the string */
+       i = strlen(list) + 1;
+       if (i <= sizeof buf)
+               bufp = buf;
+       else
+               bufp = xalloc(i);
+       strcpy(bufp, denlstring(list, FALSE, TRUE));
+
+       for (p = bufp; *p != '\0'; )
        {
                auto char *delimptr;
                register ADDRESS *a;
        {
                auto char *delimptr;
                register ADDRESS *a;
@@ -105,27 +122,6 @@ sendto(list, copyf, ctladdr, qflags)
                        a->q_flags |= ctladdr->q_flags & ~QPRIMARY;
                a->q_flags |= qflags;
 
                        a->q_flags |= ctladdr->q_flags & ~QPRIMARY;
                a->q_flags |= qflags;
 
-               /* see if this should be marked as a primary address */
-               if (ctladdr == NULL ||
-                   (firstone && *p == '\0' && bitset(QPRIMARY, ctladdr->q_flags)))
-                       a->q_flags |= QPRIMARY;
-
-               if (ctladdr != NULL && sameaddr(ctladdr, a))
-                       ctladdr->q_flags |= QSELFREF;
-               al = a;
-               firstone = FALSE;
-       }
-
-       /* arrange to send to everyone on the local send list */
-       prev = sibl = NULL;
-       if (ctladdr != NULL)
-               prev = ctladdr->q_child;
-       while (al != NULL)
-       {
-               register ADDRESS *a = al;
-               extern ADDRESS *recipient();
-
-               al = a->q_next;
                sibl = recipient(a);
                if (sibl != NULL)
                {
                sibl = recipient(a);
                if (sibl != NULL)
                {
@@ -145,6 +141,8 @@ sendto(list, copyf, ctladdr, qflags)
        }
 
        e->e_to = oldto;
        }
 
        e->e_to = oldto;
+       if (bufp != buf)
+               free(bufp);
        return (naddrs);
        if (ctladdr != NULL)
                ctladdr->q_child = prev;
        return (naddrs);
        if (ctladdr != NULL)
                ctladdr->q_child = prev;
@@ -194,6 +192,7 @@ addrref(a, r)
 **             sendq -- a pointer to the head of a queue to put the
 **                     recipient in.  Duplicate supression is done
 **                     in this queue.
 **             sendq -- a pointer to the head of a queue to put the
 **                     recipient in.  Duplicate supression is done
 **                     in this queue.
+**             aliaslevel -- the current alias nesting depth.
 **             e -- the current envelope.
 **
 **     Returns:
 **             e -- the current envelope.
 **
 **     Returns:
@@ -205,9 +204,10 @@ addrref(a, r)
 
 ADDRESS *
 ADDRESS *
 
 ADDRESS *
 ADDRESS *
-recipient(a, sendq, e)
+recipient(a, sendq, aliaslevel, e)
        register ADDRESS *a;
        register ADDRESS **sendq;
        register ADDRESS *a;
        register ADDRESS **sendq;
+       int aliaslevel;
        register ENVELOPE *e;
 {
        register ADDRESS *q;
        register ENVELOPE *e;
 {
        register ADDRESS *q;
@@ -216,17 +216,20 @@ recipient(a, sendq, e)
        register char *p;
        bool quoted = FALSE;            /* set if the addr has a quote bit */
        int findusercount = 0;
        register char *p;
        bool quoted = FALSE;            /* set if the addr has a quote bit */
        int findusercount = 0;
+       bool initialdontsend = bitset(QDONTSEND, a->q_flags);
        int i;
        char *buf;
        int i;
        char *buf;
-       char buf0[MAXNAME];             /* unquoted image of the user name */
+       char buf0[MAXNAME + 1];         /* unquoted image of the user name */
        extern int safefile();
 
        e->e_to = a->q_paddr;
        m = a->q_mailer;
        errno = 0;
        extern int safefile();
 
        e->e_to = a->q_paddr;
        m = a->q_mailer;
        errno = 0;
+       if (aliaslevel == 0)
+               a->q_flags |= QPRIMARY;
        if (tTd(26, 1))
        {
        if (tTd(26, 1))
        {
-               printf("\nrecipient: ");
+               printf("\nrecipient (%d): ", aliaslevel);
                printaddr(a, FALSE);
        }
 
                printaddr(a, FALSE);
        }
 
@@ -240,9 +243,11 @@ recipient(a, sendq, e)
        }
 
        /* break aliasing loops */
        }
 
        /* break aliasing loops */
-       if (AliasLevel > MAXRCRSN)
+       if (aliaslevel > MAXRCRSN)
        {
        {
-               usrerr("554 aliasing/forwarding loop broken");
+               a->q_status = "5.4.6";
+               usrerr("554 aliasing/forwarding loop broken (%d aliases deep; %d max",
+                       aliaslevel, MAXRCRSN);
                return (NULL);
        }
 
                return (NULL);
        }
 
@@ -252,7 +257,7 @@ recipient(a, sendq, e)
 
        /* get unquoted user for file, program or user.name check */
        i = strlen(a->q_user);
 
        /* get unquoted user for file, program or user.name check */
        i = strlen(a->q_user);
-       if (i >= sizeof buf)
+       if (i >= sizeof buf0)
                buf = xalloc(i + 1);
        else
                buf = buf0;
                buf = xalloc(i + 1);
        else
                buf = buf0;
@@ -270,17 +275,20 @@ recipient(a, sendq, e)
                if (a->q_alias == NULL)
                {
                        a->q_flags |= QBADADDR;
                if (a->q_alias == NULL)
                {
                        a->q_flags |= QBADADDR;
+                       a->q_status = "5.7.1";
                        usrerr("550 Cannot mail directly to programs");
                }
                else if (bitset(QBOGUSSHELL, a->q_alias->q_flags))
                {
                        a->q_flags |= QBADADDR;
                        usrerr("550 Cannot mail directly to programs");
                }
                else if (bitset(QBOGUSSHELL, a->q_alias->q_flags))
                {
                        a->q_flags |= QBADADDR;
+                       a->q_status = "5.7.1";
                        usrerr("550 User %s@%s doesn't have a valid shell for mailing to programs",
                                a->q_alias->q_ruser, MyHostName);
                }
                else if (bitset(QUNSAFEADDR, a->q_alias->q_flags))
                {
                        a->q_flags |= QBADADDR;
                        usrerr("550 User %s@%s doesn't have a valid shell for mailing to programs",
                                a->q_alias->q_ruser, MyHostName);
                }
                else if (bitset(QUNSAFEADDR, a->q_alias->q_flags))
                {
                        a->q_flags |= QBADADDR;
+                       a->q_status = "5.7.1";
                        usrerr("550 Address %s is unsafe for mailing to programs",
                                a->q_alias->q_paddr);
                }
                        usrerr("550 Address %s is unsafe for mailing to programs",
                                a->q_alias->q_paddr);
                }
@@ -348,6 +356,7 @@ recipient(a, sendq, e)
                if (a->q_alias == NULL)
                {
                        a->q_flags |= QBADADDR;
                if (a->q_alias == NULL)
                {
                        a->q_flags |= QBADADDR;
+                       a->q_status = "5.7.1";
                        usrerr("550 Cannot mail directly to :include:s");
                }
                else
                        usrerr("550 Cannot mail directly to :include:s");
                }
                else
@@ -355,7 +364,7 @@ recipient(a, sendq, e)
                        int ret;
 
                        message("including file %s", a->q_user);
                        int ret;
 
                        message("including file %s", a->q_user);
-                       ret = include(a->q_user, FALSE, a, sendq, e);
+                       ret = include(a->q_user, FALSE, a, sendq, aliaslevel, e);
                        if (transienterror(ret))
                        {
 #ifdef LOG
                        if (transienterror(ret))
                        {
 #ifdef LOG
@@ -372,6 +381,7 @@ recipient(a, sendq, e)
                        else if (ret != 0)
                        {
                                a->q_flags |= QBADADDR;
                        else if (ret != 0)
                        {
                                a->q_flags |= QBADADDR;
+                               a->q_status = "5.2.4";
                                usrerr("550 Cannot open %s: %s",
                                        a->q_user, errstring(ret));
                        }
                                usrerr("550 Cannot open %s: %s",
                                        a->q_user, errstring(ret));
                        }
@@ -385,39 +395,44 @@ recipient(a, sendq, e)
                if (a->q_alias == NULL)
                {
                        a->q_flags |= QBADADDR;
                if (a->q_alias == NULL)
                {
                        a->q_flags |= QBADADDR;
+                       a->q_status = "5.7.1";
                        usrerr("550 Cannot mail directly to files");
                }
                else if (bitset(QBOGUSSHELL, a->q_alias->q_flags))
                {
                        a->q_flags |= QBADADDR;
                        usrerr("550 Cannot mail directly to files");
                }
                else if (bitset(QBOGUSSHELL, a->q_alias->q_flags))
                {
                        a->q_flags |= QBADADDR;
+                       a->q_status = "5.7.1";
                        usrerr("550 User %s@%s doesn't have a valid shell for mailing to files",
                                a->q_alias->q_ruser, MyHostName);
                }
                else if (bitset(QUNSAFEADDR, a->q_alias->q_flags))
                {
                        a->q_flags |= QBADADDR;
                        usrerr("550 User %s@%s doesn't have a valid shell for mailing to files",
                                a->q_alias->q_ruser, MyHostName);
                }
                else if (bitset(QUNSAFEADDR, a->q_alias->q_flags))
                {
                        a->q_flags |= QBADADDR;
+                       a->q_status = "5.7.1";
                        usrerr("550 Address %s is unsafe for mailing to files",
                                a->q_alias->q_paddr);
                }
                        usrerr("550 Address %s is unsafe for mailing to files",
                                a->q_alias->q_paddr);
                }
-               else if (!writable(buf, getctladdr(a), SFF_ANYFILE))
+               else if (!writable(buf, getctladdr(a), SFF_CREAT))
                {
                        a->q_flags |= QBADADDR;
                {
                        a->q_flags |= QBADADDR;
-                       giveresponse(EX_CANTCREAT, m, NULL, a->q_alias, e);
+                       giveresponse(EX_CANTCREAT, m, NULL, a->q_alias,
+                                    (time_t) 0, e);
                }
        }
 
        /* try aliasing */
                }
        }
 
        /* try aliasing */
-       if (!bitset(QDONTSEND, a->q_flags) && bitnset(M_ALIASABLE, m->m_flags))
-               alias(a, sendq, e);
+       if (!quoted && !bitset(QDONTSEND, a->q_flags) &&
+           bitnset(M_ALIASABLE, m->m_flags))
+               alias(a, sendq, aliaslevel, e);
 
 
-# ifdef USERDB
+# if USERDB
        /* if not aliased, look it up in the user database */
        if (!bitset(QDONTSEND|QNOTREMOTE|QVERIFIED, a->q_flags) &&
            bitnset(M_CHECKUDB, m->m_flags))
        {
                extern int udbexpand();
 
        /* if not aliased, look it up in the user database */
        if (!bitset(QDONTSEND|QNOTREMOTE|QVERIFIED, a->q_flags) &&
            bitnset(M_CHECKUDB, m->m_flags))
        {
                extern int udbexpand();
 
-               if (udbexpand(a, sendq, e) == EX_TEMPFAIL)
+               if (udbexpand(a, sendq, aliaslevel, e) == EX_TEMPFAIL)
                {
                        a->q_flags |= QQUEUEUP;
                        if (e->e_message == NULL)
                {
                        a->q_flags |= QQUEUEUP;
                        if (e->e_message == NULL)
@@ -453,7 +468,7 @@ recipient(a, sendq, e)
            ConfigLevel >= 2 && RewriteRules[5] != NULL &&
            bitnset(M_TRYRULESET5, m->m_flags))
        {
            ConfigLevel >= 2 && RewriteRules[5] != NULL &&
            bitnset(M_TRYRULESET5, m->m_flags))
        {
-               maplocaluser(a, sendq, e);
+               maplocaluser(a, sendq, aliaslevel + 1, e);
        }
 
        /*
        }
 
        /*
@@ -473,11 +488,13 @@ recipient(a, sendq, e)
                if (pw == NULL)
                {
                        a->q_flags |= QBADADDR;
                if (pw == NULL)
                {
                        a->q_flags |= QBADADDR;
-                       giveresponse(EX_NOUSER, m, NULL, a->q_alias, e);
+                       a->q_status = "5.1.1";
+                       giveresponse(EX_NOUSER, m, NULL, a->q_alias,
+                                    (time_t) 0, e);
                }
                else
                {
                }
                else
                {
-                       char nbuf[MAXNAME];
+                       char nbuf[MAXNAME + 1];
 
                        if (fuzzy)
                        {
 
                        if (fuzzy)
                        {
@@ -486,6 +503,7 @@ recipient(a, sendq, e)
                                if (findusercount++ > 3)
                                {
                                        a->q_flags |= QBADADDR;
                                if (findusercount++ > 3)
                                {
                                        a->q_flags |= QBADADDR;
+                                       a->q_status = "5.4.6";
                                        usrerr("554 aliasing/forwarding loop for %s broken",
                                                pw->pw_name);
                                        goto done;
                                        usrerr("554 aliasing/forwarding loop for %s broken",
                                                pw->pw_name);
                                        goto done;
@@ -506,40 +524,104 @@ recipient(a, sendq, e)
                        buildfname(pw->pw_gecos, pw->pw_name, nbuf);
                        if (nbuf[0] != '\0')
                                a->q_fullname = newstr(nbuf);
                        buildfname(pw->pw_gecos, pw->pw_name, nbuf);
                        if (nbuf[0] != '\0')
                                a->q_fullname = newstr(nbuf);
-                       if (pw->pw_shell != NULL && pw->pw_shell[0] != '\0' &&
-                           !usershellok(pw->pw_shell))
+                       if (!usershellok(pw->pw_name, pw->pw_shell))
                        {
                                a->q_flags |= QBOGUSSHELL;
                        }
                        {
                                a->q_flags |= QBOGUSSHELL;
                        }
-                       if (!quoted)
-                               forward(a, sendq, e);
+                       if (bitset(EF_VRFYONLY, e->e_flags))
+                       {
+                               /* don't do any more now */
+                               a->q_flags |= QVERIFIED;
+                       }
+                       else if (!quoted)
+                               forward(a, sendq, aliaslevel, e);
                }
        }
        if (!bitset(QDONTSEND, a->q_flags))
                e->e_nrcpts++;
 
   testselfdestruct:
                }
        }
        if (!bitset(QDONTSEND, a->q_flags))
                e->e_nrcpts++;
 
   testselfdestruct:
+       a->q_flags |= QTHISPASS;
        if (tTd(26, 8))
        {
                printf("testselfdestruct: ");
        if (tTd(26, 8))
        {
                printf("testselfdestruct: ");
-               printaddr(a, TRUE);
+               printaddr(a, FALSE);
+               if (tTd(26, 10))
+               {
+                       printf("SENDQ:\n");
+                       printaddr(*sendq, TRUE);
+                       printf("----\n");
+               }
        }
        if (a->q_alias == NULL && a != &e->e_from &&
            bitset(QDONTSEND, a->q_flags))
        {
        }
        if (a->q_alias == NULL && a != &e->e_from &&
            bitset(QDONTSEND, a->q_flags))
        {
-               q = *sendq;
-               while (q != NULL && bitset(QDONTSEND, q->q_flags))
-                       q = q->q_next;
+               for (q = *sendq; q != NULL; q = q->q_next)
+               {
+                       if (!bitset(QDONTSEND, q->q_flags) &&
+                           bitset(QTHISPASS, q->q_flags))
+                               break;
+               }
                if (q == NULL)
                {
                        a->q_flags |= QBADADDR;
                if (q == NULL)
                {
                        a->q_flags |= QBADADDR;
+                       a->q_status = "5.4.6";
                        usrerr("554 aliasing/forwarding loop broken");
                }
        }
 
   done:
                        usrerr("554 aliasing/forwarding loop broken");
                }
        }
 
   done:
+       a->q_flags |= QTHISPASS;
        if (buf != buf0)
                free(buf);
        if (buf != buf0)
                free(buf);
+
+       /*
+       **  If we are at the top level, check to see if this has
+       **  expanded to exactly one address.  If so, it can inherit
+       **  the primaryness of the address.
+       **
+       **  While we're at it, clear the QTHISPASS bits.
+       */
+
+       if (aliaslevel == 0)
+       {
+               int nrcpts = 0;
+               ADDRESS *only;
+
+               for (q = *sendq; q != NULL; q = q->q_next)
+               {
+                       if (bitset(QTHISPASS, q->q_flags) &&
+                           !bitset(QDONTSEND|QBADADDR, q->q_flags))
+                       {
+                               nrcpts++;
+                               only = q;
+                       }
+                       q->q_flags &= ~QTHISPASS;
+               }
+               if (nrcpts == 1)
+               {
+                       /* check to see if this actually got a new owner */
+                       q = only;
+                       while ((q = q->q_alias) != NULL)
+                       {
+                               if (q->q_owner != NULL)
+                                       break;
+                       }
+                       if (q == NULL)
+                               only->q_flags |= QPRIMARY;
+               }
+               else if (!initialdontsend && nrcpts > 0)
+               {
+                       /* arrange for return receipt */
+                       e->e_flags |= EF_SENDRECEIPT;
+                       a->q_flags |= QEXPANDED;
+                       if (e->e_xfp != NULL)
+                               fprintf(e->e_xfp,
+                                       "%s... expanded to multiple addresses\n",
+                                       a->q_paddr);
+               }
+       }
+
        return (a);
 
        return (a);
        return (a);
 
        return (a);
@@ -574,14 +656,13 @@ finduser(name, fuzzyp)
 {
        register struct passwd *pw;
        register char *p;
 {
        register struct passwd *pw;
        register char *p;
-       extern struct passwd *getpwent();
-       extern struct passwd *getpwnam();
 
        if (tTd(29, 4))
                printf("finduser(%s): ", name);
 
        *fuzzyp = FALSE;
 
 
        if (tTd(29, 4))
                printf("finduser(%s): ", name);
 
        *fuzzyp = FALSE;
 
+#ifdef HESIOD
        /* DEC Hesiod getpwnam accepts numeric strings -- short circuit it */
        for (p = name; *p != '\0'; p++)
                if (!isascii(*p) || !isdigit(*p))
        /* DEC Hesiod getpwnam accepts numeric strings -- short circuit it */
        for (p = name; *p != '\0'; p++)
                if (!isascii(*p) || !isdigit(*p))
@@ -592,16 +673,17 @@ finduser(name, fuzzyp)
                        printf("failed (numeric input)\n");
                return NULL;
        }
                        printf("failed (numeric input)\n");
                return NULL;
        }
+#endif
 
        /* look up this login name using fast path */
 
        /* look up this login name using fast path */
-       if ((pw = getpwnam(name)) != NULL)
+       if ((pw = sm_getpwnam(name)) != NULL)
        {
                if (tTd(29, 4))
                        printf("found (non-fuzzy)\n");
                return (pw);
        }
 
        {
                if (tTd(29, 4))
                        printf("found (non-fuzzy)\n");
                return (pw);
        }
 
-#ifdef MATCHGECOS
+#if MATCHGECOS
        /* see if fuzzy matching allowed */
        if (!MatchGecos)
        {
        /* see if fuzzy matching allowed */
        if (!MatchGecos)
        {
@@ -671,35 +753,10 @@ writable(filename, ctladdr, flags)
 {
        uid_t euid;
        gid_t egid;
 {
        uid_t euid;
        gid_t egid;
-       int bits;
-       register char *p;
        char *uname;
        char *uname;
-       struct stat stb;
-       extern char RealUserName[];
 
        if (tTd(29, 5))
 
        if (tTd(29, 5))
-               printf("writable(%s, %x)\n", filename, flags);
-
-#ifdef HASLSTAT
-       if ((bitset(SFF_NOSLINK, flags) ? lstat(filename, &stb)
-                                       : stat(filename, &stb)) < 0)
-#else
-       if (stat(filename, &stb) < 0)
-#endif
-       {
-               /* file does not exist -- see if directory is safe */
-               p = strrchr(filename, '/');
-               if (p == NULL)
-               {
-                       errno = ENOTDIR;
-                       return FALSE;
-               }
-               *p = '\0';
-               errno = safefile(filename, RealUid, RealGid, RealUserName,
-                                SFF_MUSTOWN, S_IWRITE|S_IEXEC);
-               *p = '/';
-               return errno == 0;
-       }
+               printf("writable(%s, 0x%x)\n", filename, flags);
 
 #ifdef SUID_ROOT_FILES_OK
        /* really ought to be passed down -- and not a good idea */
 
 #ifdef SUID_ROOT_FILES_OK
        /* really ought to be passed down -- and not a good idea */
@@ -710,26 +767,29 @@ writable(filename, ctladdr, flags)
        **  File does exist -- check that it is writable.
        */
 
        **  File does exist -- check that it is writable.
        */
 
-       if (bitset(0111, stb.st_mode))
-       {
-               if (tTd(29, 5))
-                       printf("failed (mode %o: x bits)\n", stb.st_mode);
-               errno = EPERM;
-               return (FALSE);
-       }
-
        if (ctladdr != NULL && geteuid() == 0)
        {
                euid = ctladdr->q_uid;
                egid = ctladdr->q_gid;
                uname = ctladdr->q_user;
        }
        if (ctladdr != NULL && geteuid() == 0)
        {
                euid = ctladdr->q_uid;
                egid = ctladdr->q_gid;
                uname = ctladdr->q_user;
        }
-       else
+       else if (bitset(SFF_RUNASREALUID, flags))
        {
                euid = RealUid;
                egid = RealGid;
                uname = RealUserName;
        }
        {
                euid = RealUid;
                egid = RealGid;
                uname = RealUserName;
        }
+       else if (FileMailer != NULL)
+       {
+               euid = FileMailer->m_uid;
+               egid = FileMailer->m_gid;
+               uname = NULL;
+       }
+       else
+       {
+               euid = egid = 0;
+               uname = NULL;
+       }
        if (euid == 0)
        {
                euid = DefUid;
        if (euid == 0)
        {
                euid = DefUid;
@@ -738,23 +798,9 @@ writable(filename, ctladdr, flags)
        if (egid == 0)
                egid = DefGid;
        if (geteuid() == 0)
        if (egid == 0)
                egid = DefGid;
        if (geteuid() == 0)
-       {
-               if (bitset(S_ISUID, stb.st_mode) &&
-                   (stb.st_uid != 0 || bitset(SFF_ROOTOK, flags)))
-               {
-                       euid = stb.st_uid;
-                       uname = NULL;
-               }
-               if (bitset(S_ISGID, stb.st_mode) &&
-                   (stb.st_gid != 0 || bitset(SFF_ROOTOK, flags)))
-                       egid = stb.st_gid;
-       }
-
-       if (tTd(29, 5))
-               printf("\teu/gid=%d/%d, st_u/gid=%d/%d\n",
-                       euid, egid, stb.st_uid, stb.st_gid);
+               flags |= SFF_SETUIDOK;
 
 
-       errno = safefile(filename, euid, egid, uname, flags, S_IWRITE);
+       errno = safefile(filename, euid, egid, uname, flags, S_IWRITE, NULL);
        return errno == 0;
 }
 \f/*
        return errno == 0;
 }
 \f/*
@@ -769,6 +815,8 @@ writable(filename, ctladdr, flags)
 **                     the important things.
 **             sendq -- a pointer to the head of the send queue
 **                     to put these addresses in.
 **                     the important things.
 **             sendq -- a pointer to the head of the send queue
 **                     to put these addresses in.
+**             aliaslevel -- the alias nesting depth.
+**             e -- the current envelope.
 **
 **     Returns:
 **             open error status
 **
 **     Returns:
 **             open error status
@@ -792,21 +840,18 @@ writable(filename, ctladdr, flags)
 */
 
 static jmp_buf CtxIncludeTimeout;
 */
 
 static jmp_buf CtxIncludeTimeout;
-static int     includetimeout();
-
-#ifndef S_IWOTH
-# define S_IWOTH       (S_IWRITE >> 6)
-#endif
+static void    includetimeout();
 
 int
 
 int
-include(fname, forwarding, ctladdr, sendq, e)
+include(fname, forwarding, ctladdr, sendq, aliaslevel, e)
        char *fname;
        bool forwarding;
        ADDRESS *ctladdr;
        ADDRESS **sendq;
        char *fname;
        bool forwarding;
        ADDRESS *ctladdr;
        ADDRESS **sendq;
+       int aliaslevel;
        ENVELOPE *e;
 {
        ENVELOPE *e;
 {
-       register FILE *fp = NULL;
+       FILE *fp = NULL;
        char *oldto = e->e_to;
        char *oldfilename = FileName;
        int oldlinenumber = LineNumber;
        char *oldto = e->e_to;
        char *oldfilename = FileName;
        int oldlinenumber = LineNumber;
@@ -817,7 +862,7 @@ include(fname, forwarding, ctladdr, sendq, e)
        gid_t savedgid, gid;
        char *uname;
        int rval = 0;
        gid_t savedgid, gid;
        char *uname;
        int rval = 0;
-       int sfflags = forwarding ? SFF_MUSTOWN : SFF_ANYFILE;
+       int sfflags = SFF_REGONLY;
        struct stat st;
        char buf[MAXLINE];
 #ifdef _POSIX_CHOWN_RESTRICTED
        struct stat st;
        char buf[MAXLINE];
 #ifdef _POSIX_CHOWN_RESTRICTED
@@ -852,34 +897,44 @@ include(fname, forwarding, ctladdr, sendq, e)
        if (tTd(27, 9))
                printf("include: old uid = %d/%d\n", getuid(), geteuid());
 
        if (tTd(27, 9))
                printf("include: old uid = %d/%d\n", getuid(), geteuid());
 
+       if (forwarding)
+               sfflags |= SFF_MUSTOWN|SFF_ROOTOK|SFF_NOSLINK;
+
        ca = getctladdr(ctladdr);
        if (ca == NULL)
        {
                uid = DefUid;
                gid = DefGid;
                uname = DefUser;
        ca = getctladdr(ctladdr);
        if (ca == NULL)
        {
                uid = DefUid;
                gid = DefGid;
                uname = DefUser;
-               saveduid = -1;
        }
        else
        {
                uid = ca->q_uid;
                gid = ca->q_gid;
                uname = ca->q_user;
        }
        else
        {
                uid = ca->q_uid;
                gid = ca->q_gid;
                uname = ca->q_user;
-#ifdef HASSETREUID
-               saveduid = geteuid();
-               savedgid = getegid();
-               if (saveduid == 0)
+       }
+#if HASSETREUID || USESETEUID
+       saveduid = geteuid();
+       savedgid = getegid();
+       if (saveduid == 0)
+       {
+               initgroups(uname, gid);
+               if (uid != 0)
                {
                {
-                       initgroups(uname, gid);
-                       if (uid != 0)
-                       {
-                               if (setreuid(0, uid) < 0)
-                                       syserr("setreuid(0, %d) failure (real=%d, eff=%d)",
-                                               uid, getuid(), geteuid());
-                       }
+# if USESETEUID
+                       if (seteuid(uid) < 0)
+                               syserr("seteuid(%d) failure (real=%d, eff=%d)",
+                                       uid, getuid(), geteuid());
+# else
+                       if (setreuid(0, uid) < 0)
+                               syserr("setreuid(0, %d) failure (real=%d, eff=%d)",
+                                       uid, getuid(), geteuid());
+# endif
+                       else
+                               sfflags |= SFF_NOPATHCHECK;
                }
                }
-#endif                   
        }
        }
+#endif
 
        if (tTd(27, 9))
                printf("include: new uid = %d/%d\n", getuid(), geteuid());
 
        if (tTd(27, 9))
                printf("include: new uid = %d/%d\n", getuid(), geteuid());
@@ -904,7 +959,7 @@ include(fname, forwarding, ctladdr, sendq, e)
                ev = NULL;
 
        /* the input file must be marked safe */
                ev = NULL;
 
        /* the input file must be marked safe */
-       rval = safefile(fname, uid, gid, uname, sfflags, S_IREAD);
+       rval = safefile(fname, uid, gid, uname, sfflags, S_IREAD, NULL);
        if (rval != 0)
        {
                /* don't use this :include: file */
        if (rval != 0)
        {
                /* don't use this :include: file */
@@ -927,17 +982,23 @@ include(fname, forwarding, ctladdr, sendq, e)
 
 resetuid:
 
 
 resetuid:
 
-#ifdef HASSETREUID
+#if HASSETREUID || USESETEUID
        if (saveduid == 0)
        {
                if (uid != 0)
                {
        if (saveduid == 0)
        {
                if (uid != 0)
                {
+# if USESETEUID
+                       if (seteuid(0) < 0)
+                               syserr("seteuid(0) failure (real=%d, eff=%d)",
+                                       getuid(), geteuid());
+# else
                        if (setreuid(-1, 0) < 0)
                                syserr("setreuid(-1, 0) failure (real=%d, eff=%d)",
                                        getuid(), geteuid());
                        if (setreuid(RealUid, 0) < 0)
                                syserr("setreuid(%d, 0) failure (real=%d, eff=%d)",
                                        RealUid, getuid(), geteuid());
                        if (setreuid(-1, 0) < 0)
                                syserr("setreuid(-1, 0) failure (real=%d, eff=%d)",
                                        getuid(), geteuid());
                        if (setreuid(RealUid, 0) < 0)
                                syserr("setreuid(%d, 0) failure (real=%d, eff=%d)",
                                        RealUid, getuid(), geteuid());
+# endif
                }
                setgid(savedgid);
        }
                }
                setgid(savedgid);
        }
@@ -976,25 +1037,27 @@ resetuid:
        }
        else
        {
        }
        else
        {
-               char *sh;
                register struct passwd *pw;
 
                register struct passwd *pw;
 
-               sh = "/SENDMAIL/ANY/SHELL/";
-               pw = getpwuid(st.st_uid);
-               if (pw != NULL)
-               {
-                       ctladdr->q_ruser = newstr(pw->pw_name);
-                       if (safechown)
-                               sh = pw->pw_shell;
-               }
+               pw = sm_getpwuid(st.st_uid);
                if (pw == NULL)
                        ctladdr->q_flags |= QBOGUSSHELL;
                if (pw == NULL)
                        ctladdr->q_flags |= QBOGUSSHELL;
-               else if(!usershellok(sh))
+               else
                {
                {
+                       char *sh;
+
+                       ctladdr->q_ruser = newstr(pw->pw_name);
                        if (safechown)
                        if (safechown)
-                               ctladdr->q_flags |= QBOGUSSHELL;
+                               sh = pw->pw_shell;
                        else
                        else
-                               ctladdr->q_flags |= QUNSAFEADDR;
+                               sh = "/SENDMAIL/ANY/SHELL/";
+                       if (!usershellok(pw->pw_name, sh))
+                       {
+                               if (safechown)
+                                       ctladdr->q_flags |= QBOGUSSHELL;
+                               else
+                                       ctladdr->q_flags |= QUNSAFEADDR;
+                       }
                }
        }
 
                }
        }
 
@@ -1034,6 +1097,22 @@ resetuid:
                        *p = '\0';
                if (buf[0] == '#' || buf[0] == '\0')
                        continue;
                        *p = '\0';
                if (buf[0] == '#' || buf[0] == '\0')
                        continue;
+
+               /* <sp>#@# introduces a comment anywhere */
+               /* for Japanese character sets */
+               for (p = buf; (p = strchr(++p, '#')) != NULL; )
+               {
+                       if (p[1] == '@' && p[2] == '#' &&
+                           isascii(p[-1]) && isspace(p[-1]) &&
+                           (p[3] == '\0' || (isascii(p[3]) && isspace(p[3]))))
+                       {
+                               p[-1] = '\0';
+                               break;
+                       }
+               }
+               if (buf[0] == '\0')
+                       continue;
+
                e->e_to = NULL;
                message("%s to %s",
                        forwarding ? "forwarding" : "sending", buf);
                e->e_to = NULL;
                message("%s to %s",
                        forwarding ? "forwarding" : "sending", buf);
@@ -1044,9 +1123,7 @@ resetuid:
                                oldto, buf);
 #endif
 
                                oldto, buf);
 #endif
 
-               AliasLevel++;
-               sendto(buf, 1, ctladdr, 0);
-               AliasLevel--;
+               nincludes += sendtolist(buf, ctladdr, sendq, aliaslevel + 1, e);
        }
 
        if (ferror(fp) && tTd(27, 3))
        }
 
        if (ferror(fp) && tTd(27, 3))
@@ -1068,7 +1145,7 @@ resetuid:
        return rval;
 }
 
        return rval;
 }
 
-static
+static void
 includetimeout()
 {
        longjmp(CtxIncludeTimeout, 1);
 includetimeout()
 {
        longjmp(CtxIncludeTimeout, 1);
@@ -1088,6 +1165,7 @@ includetimeout()
 **                     send queue.
 */
 
 **                     send queue.
 */
 
+void
 sendtoargv(argv, e)
        register char **argv;
        register ENVELOPE *e;
 sendtoargv(argv, e)
        register char **argv;
        register ENVELOPE *e;
@@ -1122,3 +1200,93 @@ getctladdr(a)
                a = a->q_alias;
        return (a);
 }
                a = a->q_alias;
        return (a);
 }
+\f/*
+**  SELF_REFERENCE -- check to see if an address references itself
+**
+**     The check is done through a chain of aliases.  If it is part of
+**     a loop, break the loop at the "best" address, that is, the one
+**     that exists as a real user.
+**
+**     This is to handle the case of:
+**             awc:            Andrew.Chang
+**             Andrew.Chang:   awc@mail.server
+**     which is a problem only on mail.server.
+**
+**     Parameters:
+**             a -- the address to check.
+**             e -- the current envelope.
+**
+**     Returns:
+**             The address that should be retained.
+*/
+
+ADDRESS *
+self_reference(a, e)
+       ADDRESS *a;
+       ENVELOPE *e;
+{
+       ADDRESS *b;             /* top entry in self ref loop */
+       ADDRESS *c;             /* entry that point to a real mail box */
+
+       if (tTd(27, 1))
+               printf("self_reference(%s)\n", a->q_paddr);
+
+       for (b = a->q_alias; b != NULL; b = b->q_alias)
+       {
+               if (sameaddr(a, b))
+                       break;
+       }
+
+       if (b == NULL)
+       {
+               if (tTd(27, 1))
+                       printf("\t... no self ref\n");
+               return NULL;
+       }
+
+       /*
+       **  Pick the first address that resolved to a real mail box
+       **  i.e has a pw entry.  The returned value will be marked
+       **  QSELFREF in recipient(), which in turn will disable alias()
+       **  from marking it QDONTSEND, which mean it will be used
+       **  as a deliverable address.
+       **
+       **  The 2 key thing to note here are:
+       **      1) we are in a recursive call sequence:
+       **              alias->sentolist->recipient->alias
+       **      2) normally, when we return back to alias(), the address
+       **         will be marked QDONTSEND, since alias() assumes the
+       **         expanded form will be used instead of the current address.
+       **         This behaviour is turned off if the address is marked
+       **         QSELFREF We set QSELFREF when we return to recipient().
+       */
+
+       c = a;
+       while (c != NULL)
+       {
+               if (bitnset(M_HASPWENT, c->q_mailer->m_flags))
+               {
+                       if (tTd(27, 2))
+                               printf("\t... getpwnam(%s)... ", c->q_user);
+                       if (sm_getpwnam(c->q_user) != NULL)
+                       {
+                               if (tTd(27, 2))
+                                       printf("found\n");
+
+                               /* ought to cache results here */
+                               if (sameaddr(b, c))
+                                       return b;
+                               else
+                                       return c;
+                       }
+                       if (tTd(27, 2))
+                               printf("failed\n");
+               }
+               c = c->q_alias;
+       }
+
+       if (tTd(27, 1))
+               printf("\t... cannot break loop for \"%s\"\n", a->q_paddr);
+
+       return NULL;
+}