xref: /csrg-svn/usr.sbin/sendmail/src/alias.c (revision 59025)

/*
 * Copyright (c) 1983 Eric P. Allman
 * Copyright (c) 1988 Regents of the University of California.
 * All rights reserved.
 *
 * %sccs.include.redist.c%
 */

# include "sendmail.h"
# include <sys/stat.h>
# include <signal.h>
# include <pwd.h>

# ifdef DBM
ERROR: DBM is no longer supported -- use NDBM instead.
# endif

# ifdef NEWDB
# include <db.h>
# endif

# ifdef NDBM
# include <ndbm.h>
# endif

#ifndef lint
#ifdef NEWDB
#ifdef NDBM
static char sccsid[] = "@(#)alias.c	6.31 (Berkeley) 04/10/93 (with NEWDB and NDBM)";
#else
static char sccsid[] = "@(#)alias.c	6.31 (Berkeley) 04/10/93 (with NEWDB)";
#endif
#else
#ifdef NDBM
static char sccsid[] = "@(#)alias.c	6.31 (Berkeley) 04/10/93 (with NDBM)";
#else
static char sccsid[] = "@(#)alias.c	6.31 (Berkeley) 04/10/93 (without NEWDB or NDBM)";
#endif
#endif
#endif /* not lint */
/*
**  ALIAS -- Compute aliases.
**
**	Scans the alias file for an alias for the given address.
**	If found, it arranges to deliver to the alias list instead.
**	Uses libdbm database if -DDBM.
**
**	Parameters:
**		a -- address to alias.
**		sendq -- a pointer to the head of the send queue
**			to put the aliases in.
**		e -- the current envelope.
**
**	Returns:
**		none
**
**	Side Effects:
**		Aliases found are expanded.
**
**	Notes:
**		If NoAlias (the "-n" flag) is set, no aliasing is
**			done.
**
**	Deficiencies:
**		It should complain about names that are aliased to
**			nothing.
*/


/*
**  Sun YP servers read the dbm files directly, so we have to build them
**  even if NEWDB
*/

#ifdef NDBM
# ifndef NEWDB
#  define IF_MAKEDBMFILES
# else
#  ifdef YPCOMPAT
#   define IF_MAKEDBMFILES		if (makedbmfiles)
#  endif
# endif
#endif

typedef union
{
#ifdef NDBM
	datum	dbm;
#endif
#ifdef NEWDB
	DBT	dbt;
#endif
	struct
	{
		char	*data;
		int	size;
	} xx;
} DBdatum;

#ifdef NEWDB
static DB	*AliasDBptr;
#endif
#ifdef NDBM
static DBM	*AliasDBMptr;
#endif

alias(a, sendq, e)
	register ADDRESS *a;
	ADDRESS **sendq;
	register ENVELOPE *e;
{
	register char *p;
	int naliases;
	char *owner;
	char obuf[MAXNAME + 6];
	extern char *aliaslookup();

	if (tTd(27, 1))
		printf("alias(%s)\n", a->q_paddr);

	/* don't realias already aliased names */
	if (bitset(QDONTSEND|QBADADDR|QVERIFIED, a->q_flags))
		return;

	e->e_to = a->q_paddr;

	/*
	**  Look up this name
	*/

	if (NoAlias)
		p = NULL;
	else
		p = aliaslookup(a->q_user);
	if (p == NULL)
		return;

	/*
	**  Match on Alias.
	**	Deliver to the target list.
	*/

	if (tTd(27, 1))
		printf("%s (%s, %s) aliased to %s\n",
		    a->q_paddr, a->q_host, a->q_user, p);
	if (bitset(EF_VRFYONLY, e->e_flags))
	{
		a->q_flags |= QVERIFIED;
		e->e_nrcpts++;
		return;
	}
	message("aliased to %s", p);
#ifdef LOG
	if (LogLevel > 9)
		syslog(LOG_INFO, "%s: alias %s => %s", e->e_id, a->q_paddr, p);
#endif
	a->q_flags &= ~QSELFREF;
	AliasLevel++;
	naliases = sendtolist(p, a, sendq, e);
	AliasLevel--;
	if (naliases > 0 && !bitset(QSELFREF, a->q_flags))
	{
		if (tTd(27, 5))
		{
			printf("alias: QDONTSEND ");
			printaddr(a, FALSE);
		}
		a->q_flags |= QDONTSEND;
	}

	/*
	**  Look for owner of alias
	*/

	(void) strcpy(obuf, "owner-");
	if (strncmp(a->q_user, "owner-", 6) == 0)
		(void) strcat(obuf, "owner");
	else
		(void) strcat(obuf, a->q_user);
	if (!bitnset(M_USR_UPPER, a->q_mailer->m_flags))
		makelower(obuf);
	owner = aliaslookup(obuf);
	if (owner != NULL)
	{
		if (strchr(owner, ',') != NULL)
			owner = obuf;
		a->q_owner = newstr(owner);
	}
}
/*
**  ALIASLOOKUP -- look up a name in the alias file.
**
**	Parameters:
**		name -- the name to look up.
**
**	Returns:
**		the value of name.
**		NULL if unknown.
**
**	Side Effects:
**		none.
**
**	Warnings:
**		The return value will be trashed across calls.
*/

char *
aliaslookup(name)
	char *name;
{
	int i;
	char keybuf[MAXNAME + 1];
# if defined(NEWDB) || defined(NDBM)
	DBdatum rhs, lhs;
	int s;
# else /* neither NEWDB nor NDBM */
	register STAB *s;
# endif

	/* create a key for fetch */
	i = strlen(name) + 1;
	if (i > sizeof keybuf)
		i = sizeof keybuf;
	bcopy(name, keybuf, i);
	if (!bitnset(M_USR_UPPER, LocalMailer->m_flags))
		makelower(keybuf);

# if defined(NEWDB) || defined(NDBM)
	lhs.xx.size = i;
	lhs.xx.data = keybuf;
# ifdef NEWDB
	if (AliasDBptr != NULL)
	{
		i = AliasDBptr->get(AliasDBptr, &lhs.dbt, &rhs.dbt, 0);
		if (i == 0)
			return (rhs.dbt.data);
	}
# ifdef NDBM
	else if (AliasDBMptr != NULL)
	{
		rhs.dbm = dbm_fetch(AliasDBMptr, lhs.dbm);
		return (rhs.dbm.dptr);
	}
# endif /* NDBM */
	return (NULL);
# else /* not NEWDB */
	rhs.dbm = dbm_fetch(AliasDBMptr, lhs.dbm);
	return (rhs.dbm.dptr);
# endif /* NEWDB */
# else /* neither NEWDB nor NDBM */
	s = stab(keybuf, ST_ALIAS, ST_FIND);
	if (s != NULL)
		return (s->s_alias);
	return (NULL);
# endif
}
/*
**  INITALIASES -- initialize for aliasing
**
**	Very different depending on whether we are running NDBM or not.
**
**	Parameters:
**		aliasfile -- location of aliases.
**		init -- if set and if NDBM, initialize the NDBM files.
**
**	Returns:
**		none.
**
**	Side Effects:
**		initializes aliases:
**		if NDBM:  opens the database.
**		if ~NDBM: reads the aliases into the symbol table.
*/

# define DBMMODE	0644

initaliases(aliasfile, init, e)
	char *aliasfile;
	bool init;
	register ENVELOPE *e;
{
#if defined(NDBM) || defined(NEWDB)
	int atcnt;
	time_t modtime;
	bool automatic = FALSE;
	char buf[MAXNAME];
#endif
	struct stat stb;
	static bool initialized = FALSE;
	static int readaliases();

	if (initialized)
		return;
	initialized = TRUE;

	if (aliasfile == NULL || stat(aliasfile, &stb) < 0)
	{
		if (aliasfile != NULL && init)
			syserr("554 Cannot open %s", aliasfile);
		NoAlias = TRUE;
		errno = 0;
		return;
	}

# if defined(NDBM) || defined(NEWDB)
	/*
	**  Check to see that the alias file is complete.
	**	If not, we will assume that someone died, and it is up
	**	to us to rebuild it.
	*/

	if (!init)
	{
# ifdef NEWDB
		(void) strcpy(buf, aliasfile);
		(void) strcat(buf, ".db");
		AliasDBptr = dbopen(buf, O_RDONLY, DBMMODE, DB_HASH, NULL);
		if (AliasDBptr == NULL)
		{
# ifdef NDBM
			AliasDBMptr = dbm_open(aliasfile, O_RDONLY, DBMMODE);
			if (AliasDBMptr == NULL)
			{
				syserr("WARNING: initaliases: cannot open %s", buf);
				NoAlias = TRUE;
				return;
			}
# else
			syserr("WARNING: initaliases: cannot open %s", buf);
			NoAlias = TRUE;
			return;
# endif
		}
# else
		AliasDBMptr = dbm_open(aliasfile, O_RDONLY, DBMMODE);
		if (AliasDBMptr == NULL)
		{
			syserr("WARNING: initaliases: cannot open DBM database %s.{pag,dir}",
				aliasfile);
			NoAlias = TRUE;
			return;
		}
# endif
	}
	atcnt = SafeAlias * 2;
	if (atcnt > 0)
	{
		while (!init && atcnt-- >= 0 && aliaslookup("@") == NULL)
		{
			/*
			**  Reinitialize alias file in case the new
			**  one is mv'ed in instead of cp'ed in.
			**
			**	Only works with new DBM -- old one will
			**	just consume file descriptors forever.
			**	If you have a dbmclose() it can be
			**	added before the sleep(30).
			*/

# ifdef NEWDB
			if (AliasDBptr != NULL)
				AliasDBptr->close(AliasDBptr);
# endif
# ifdef NDBM
			if (AliasDBMptr != NULL)
				dbm_close(AliasDBMptr);
# endif

			sleep(30);
# ifdef NEWDB
			(void) strcpy(buf, aliasfile);
			(void) strcat(buf, ".db");
			AliasDBptr =
			    dbopen(buf, O_RDONLY, DBMMODE, DB_HASH, NULL);
			if (AliasDBptr == NULL)
			{
# ifdef NDBM
				AliasDBMptr = dbm_open(aliasfile, O_RDONLY, DBMMODE);
# else
				syserr("WARNING: initaliases: cannot open %s", buf);
				NoAlias = TRUE;
				return;
# endif
			}
# else
# ifdef NDBM
			AliasDBMptr = dbm_open(aliasfile, O_RDONLY, DBMMODE);
			if (AliasDBMptr == NULL)
			{
				syserr("WARNING: initaliases: cannot open DBM database %s.{pag,dir}",
					aliasfile);
				NoAlias = TRUE;
				return;
			}
# endif
# endif
		}
	}
	else
		atcnt = 1;

	/*
	**  See if the NDBM version of the file is out of date with
	**  the text version.  If so, go into 'init' mode automatically.
	**	This only happens if our effective userid owns the DBM.
	**	Note the unpalatable hack to see if the stat succeeded.
	*/

	modtime = stb.st_mtime;
	(void) strcpy(buf, aliasfile);
# ifdef NEWDB
	(void) strcat(buf, ".db");
# else
	(void) strcat(buf, ".pag");
# endif
	stb.st_ino = 0;
	if (!init && (stat(buf, &stb) < 0 || stb.st_mtime < modtime || atcnt < 0))
	{
		errno = 0;
		if (AutoRebuild && stb.st_ino != 0 && stb.st_uid == geteuid())
		{
			init = TRUE;
			automatic = TRUE;
			message("rebuilding alias database");
#ifdef LOG
			if (LogLevel > 14)
				syslog(LOG_INFO, "rebuilding alias database");
#endif /* LOG */
		}
		else
		{
#ifdef LOG
			if (LogLevel > 3)
				syslog(LOG_INFO, "alias database out of date");
#endif /* LOG */
			message("Warning: alias database out of date");
		}
	}


	/*
	**  If necessary, load the NDBM file.
	**	If running without NDBM, load the symbol table.
	*/

	if (init)
	{
#ifdef LOG
		if (LogLevel > 7)
		{
			extern char *username();

			syslog(LOG_NOTICE, "alias database %srebuilt by %s",
				automatic ? "auto" : "", username());
		}
#endif /* LOG */
		readaliases(aliasfile, TRUE, e);
	}
# else /* NDBM */
	readaliases(aliasfile, init, e);
# endif /* NDBM */
}
/*
**  READALIASES -- read and process the alias file.
**
**	This routine implements the part of initaliases that occurs
**	when we are not going to use the DBM stuff.
**
**	Parameters:
**		aliasfile -- the pathname of the alias file master.
**		init -- if set, initialize the NDBM stuff.
**
**	Returns:
**		none.
**
**	Side Effects:
**		Reads aliasfile into the symbol table.
**		Optionally, builds the .dir & .pag files.
*/

static
readaliases(aliasfile, init, e)
	char *aliasfile;
	bool init;
	register ENVELOPE *e;
{
	register char *p;
	char *rhs;
	bool skipping;
	int naliases, bytes, longest;
	FILE *af;
	bool makedbmfiles;
	void (*oldsigint)();
	ADDRESS al, bl;
	register STAB *s;
# ifdef NEWDB
	DB *dbp;
# endif
# ifdef NDBM
	DBM *dbmp;
# endif
	char line[BUFSIZ];
	extern bool lockfile();

	if ((af = fopen(aliasfile, "r+")) == NULL)
	{
		if (init)
			syserr("554 Can't open %s", aliasfile);
		else if (tTd(27, 1))
			printf("Can't open %s\n", aliasfile);
		errno = 0;
		NoAlias++;
		return;
	}

# if defined(NDBM) || defined(NEWDB)
	/* see if someone else is rebuilding the alias file already */
	if (!lockfile(fileno(af), aliasfile, LOCK_EX|LOCK_NB))
	{
		/* yes, they are -- wait until done and then return */
		message("Alias file is already being rebuilt");
		if (OpMode != MD_INITALIAS)
		{
			/* wait for other rebuild to complete */
			(void) lockfile(fileno(af), aliasfile, LOCK_EX);
		}
		(void) fclose(af);
		errno = 0;
		return;
	}
# endif /* NDBM */

	/*
	**  If initializing, create the new DBM files.
	*/

	if (init)
	{
		oldsigint = signal(SIGINT, SIG_IGN);
# ifdef NEWDB
		(void) strcpy(line, aliasfile);
		(void) strcat(line, ".db");
		dbp = dbopen(line,
		    O_RDWR|O_CREAT|O_TRUNC, DBMMODE, DB_HASH, NULL);
		if (dbp == NULL)
		{
			syserr("readaliases: cannot create %s", line);
			(void) signal(SIGINT, oldsigint);
			return;
		}
# endif
# ifdef IF_MAKEDBMFILES
# ifdef NEWDB
		makedbmfiles = access("/var/yp/Makefile", R_OK) == 0;
# endif
		IF_MAKEDBMFILES
		{
			dbmp = dbm_open(aliasfile,
					       O_RDWR|O_CREAT|O_TRUNC, DBMMODE);
			if (dbmp == NULL)
			{
				syserr("readaliases: cannot create %s.{dir,pag}",
					aliasfile);
				(void) signal(SIGINT, oldsigint);
				return;
			}
		}
# endif
	}

	/*
	**  Read and interpret lines
	*/

	FileName = aliasfile;
	LineNumber = 0;
	naliases = bytes = longest = 0;
	skipping = FALSE;
	while (fgets(line, sizeof (line), af) != NULL)
	{
		int lhssize, rhssize;

		LineNumber++;
		p = strchr(line, '\n');
		if (p != NULL)
			*p = '\0';
		switch (line[0])
		{
		  case '#':
		  case '\0':
			skipping = FALSE;
			continue;

		  case ' ':
		  case '\t':
			if (!skipping)
				syserr("554 Non-continuation line starts with space");
			skipping = TRUE;
			continue;
		}
		skipping = FALSE;

		/*
		**  Process the LHS
		**	Find the colon separator, and parse the address.
		**	It should resolve to a local name -- this will
		**	be checked later (we want to optionally do
		**	parsing of the RHS first to maximize error
		**	detection).
		*/

		for (p = line; *p != '\0' && *p != ':' && *p != '\n'; p++)
			continue;
		if (*p++ != ':')
		{
			syserr("554 missing colon");
			continue;
		}
		if (parseaddr(line, &al, 1, ':', NULL, e) == NULL)
		{
			syserr("554 illegal alias name");
			continue;
		}

		/*
		**  Process the RHS.
		**	'al' is the internal form of the LHS address.
		**	'p' points to the text of the RHS.
		*/

		while (isascii(*p) && isspace(*p))
			p++;
		rhs = p;
		for (;;)
		{
			register char c;
			register char *nlp;

			nlp = &p[strlen(p)];
			if (nlp[-1] == '\n')
				*--nlp = '\0';

			if (init && CheckAliases)
			{
				/* do parsing & compression of addresses */
				while (*p != '\0')
				{
					auto char *delimptr;

					while ((isascii(*p) && isspace(*p)) ||
								*p == ',')
						p++;
					if (*p == '\0')
						break;
					if (parseaddr(p, &bl, -1, ',', &delimptr, e) == NULL)
						usrerr("553 %s... bad address", p);
					p = delimptr;
				}
			}
			else
			{
				p = nlp;
			}

			/* see if there should be a continuation line */
			c = fgetc(af);
			if (!feof(af))
				(void) ungetc(c, af);
			if (c != ' ' && c != '\t')
				break;

			/* read continuation line */
			if (fgets(p, sizeof line - (p - line), af) == NULL)
				break;
			LineNumber++;

			/* check for line overflow */
			if (strchr(p, '\n') == NULL)
			{
				usrerr("554 alias too long");
				break;
			}
		}
		if (al.q_mailer != LocalMailer)
		{
			syserr("554 cannot alias non-local names");
			continue;
		}

		/*
		**  Insert alias into symbol table or DBM file
		*/

		lhssize = strlen(al.q_user) + 1;
		if (!bitnset(M_USR_UPPER, al.q_mailer->m_flags))
			makelower(al.q_user);
		rhssize = strlen(rhs) + 1;

# if defined(NDBM) || defined(NEWDB)
		if (init)
		{
			DBdatum key, content;
			int putstat;

			key.xx.size = lhssize;
			key.xx.data = al.q_user;
			content.xx.size = rhssize;
			content.xx.data = rhs;
# ifdef NEWDB
			putstat = dbp->put(dbp, &key.dbt, &content.dbt,
					   R_NOOVERWRITE);
			if (putstat > 0)
			{
				usrerr("050 Warning: duplicate alias name %s",
					al.q_user);
				putstat = dbp->put(dbp, &key.dbt,
						   &content.dbt, 0);
			}
			if (putstat != 0)
				syserr("readaliases: db put (%s)", al.q_user);
# endif
# ifdef IF_MAKEDBMFILES
			IF_MAKEDBMFILES
			{
				putstat = dbm_store(dbmp, key.dbm, content.dbm,
						    DBM_INSERT);
				if (putstat > 0)
				{
					usrerr("050 Warning: duplicate alias name %s",
						al.q_user);
					putstat = dbm_store(dbmp, key.dbm,
							content.dbm, DBM_REPLACE);
				}
				if (putstat != 0)
					syserr("readaliases: dbm store (%s)",
						al.q_user);
			}
# endif
			if (al.q_paddr != NULL)
				free(al.q_paddr);
			if (al.q_host != NULL)
				free(al.q_host);
			if (al.q_user != NULL)
				free(al.q_user);
		}
		else
# endif /* NDBM */
		{
			s = stab(al.q_user, ST_ALIAS, ST_ENTER);
			s->s_alias = newstr(rhs);
		}

		/* statistics */
		naliases++;
		bytes += lhssize + rhssize;
		if (rhssize > longest)
			longest = rhssize;
	}

# if defined(NDBM) || defined(NEWDB)
	if (init)
	{
		/* add the distinquished alias "@" */
		DBdatum key;

		key.xx.size = 2;
		key.xx.data = "@";
# ifdef NEWDB
		if (dbp->sync(dbp) != 0 ||
		    dbp->put(dbp, &key.dbt, &key.dbt, 0) != 0 ||
		    dbp->close(dbp) != 0)
			syserr("readaliases: db close failure");
# endif
# ifdef IF_MAKEDBMFILES
		IF_MAKEDBMFILES
		{
#ifdef YPCOMPAT
			static void nis_magic P((DBM *dbmp));

			nis_magic(dbmp);
#endif
			if (dbm_store(dbmp, key.dbm, key.dbm, DBM_REPLACE) != 0 ||
			    dbm_error(dbmp))
				syserr("readaliases: dbm close failure");
			dbm_close(dbmp);
		}
# endif

		/* restore the old signal */
		(void) signal(SIGINT, oldsigint);
	}
# endif /* NDBM */

	/* closing the alias file drops the lock */
	(void) fclose(af);
	e->e_to = NULL;
	FileName = NULL;
	message("%d aliases, longest %d bytes, %d bytes total",
			naliases, longest, bytes);
# ifdef LOG
	if (LogLevel > 7)
		syslog(LOG_INFO, "%d aliases, longest %d bytes, %d bytes total",
			naliases, longest, bytes);
# endif /* LOG */
}
/*
**  NIS_MAGIC -- Add NIS magic dbm data
**
**	This adds the magic entries needed by SunOS to make this a valid
**	NIS map.
**
**	Parameters:
**		dbmp -- a pointer to the DBM structure.
**
**	Returns:
**		none.
*/

# ifdef YPCOMPAT

static void
nis_magic(dbmp)
	DBM *dbmp;
{
	int i;
	static datum key[2] =
	{
		{ "YP_LAST_MODIFIED",	sizeof "YP_LAST_MODIFIED" - 1 },
		{ "YP_MASTER_NAME",	sizeof "YP_MASTER_NAME" - 1 },
	};
	datum contents[2];
	char tbuf[12];
	char hbuf[MAXHOSTNAMELEN];

	(void) sprintf(tbuf, "%010ld", curtime());
	contents[0].dptr = tbuf;
	contents[0].dsize = strlen(tbuf);

	(void) myhostname(hbuf, sizeof hbuf);
	contents[1].dptr = hbuf;
	contents[1].dsize = strlen(hbuf);

	for (i = 0; i < sizeof key / sizeof *key; i++)
	{
		if (dbm_store(dbmp, key[i], contents[i], DBM_REPLACE) != 0 ||
		    dbm_error(dbmp))
			syserr("nis_magic: dbm_store failure");
	}
}

# endif
/*
**  FORWARD -- Try to forward mail
**
**	This is similar but not identical to aliasing.
**
**	Parameters:
**		user -- the name of the user who's mail we would like
**			to forward to.  It must have been verified --
**			i.e., the q_home field must have been filled
**			in.
**		sendq -- a pointer to the head of the send queue to
**			put this user's aliases in.
**
**	Returns:
**		none.
**
**	Side Effects:
**		New names are added to send queues.
*/

forward(user, sendq, e)
	ADDRESS *user;
	ADDRESS **sendq;
	register ENVELOPE *e;
{
	char *pp;
	char *ep;

	if (tTd(27, 1))
		printf("forward(%s)\n", user->q_paddr);

	if (user->q_mailer != LocalMailer || bitset(QBADADDR, user->q_flags))
		return;
	if (user->q_home == NULL)
	{
		syserr("554 forward: no home");
		user->q_home = "/nosuchdirectory";
	}

	/* good address -- look for .forward file in home */
	define('z', user->q_home, e);
	define('u', user->q_user, e);
	define('h', user->q_host, e);
	if (ForwardPath == NULL)
		ForwardPath = newstr("\201z/.forward");

	for (pp = ForwardPath; pp != NULL; pp = ep)
	{
		int err;
		char buf[MAXPATHLEN+1];

		ep = strchr(pp, ':');
		if (ep != NULL)
			*ep = '\0';
		expand(pp, buf, &buf[sizeof buf - 1], e);
		if (ep != NULL)
			*ep++ = ':';
		if (tTd(27, 3))
			printf("forward: trying %s\n", buf);
		err = include(buf, TRUE, user, sendq, e);
		if (err == 0)
			break;
		if (transienterror(err))
		{
			/* we have to suspend this message */
			user->q_flags |= QQUEUEUP|QDONTSEND;
			return;
		}
	}
}