[dragonfly.git] / libexec / dma / mail.c

/*
 * Copyright (c) 2008 The DragonFly Project.  All rights reserved.
 *
 * This code is derived from software contributed to The DragonFly Project
 * by Simon 'corecode' Schubert <corecode@fs.ei.tum.de>.
 *
 * Redistribution and use in source and binary forms, with or without
 * modification, are permitted provided that the following conditions
 * are met:
 *
 * 1. Redistributions of source code must retain the above copyright
 *    notice, this list of conditions and the following disclaimer.
 * 2. Redistributions in binary form must reproduce the above copyright
 *    notice, this list of conditions and the following disclaimer in
 *    the documentation and/or other materials provided with the
 *    distribution.
 * 3. Neither the name of The DragonFly Project nor the names of its
 *    contributors may be used to endorse or promote products derived
 *    from this software without specific, prior written permission.
 *
 * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
 * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
 * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS
 * FOR A PARTICULAR PURPOSE ARE DISCLAIMED.  IN NO EVENT SHALL THE
 * COPYRIGHT HOLDERS OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT,
 * INCIDENTAL, SPECIAL, EXEMPLARY OR CONSEQUENTIAL DAMAGES (INCLUDING,
 * BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
 * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED
 * AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY,
 * OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT
 * OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
 * SUCH DAMAGE.
 */

#include <errno.h>
#include <inttypes.h>
#include <signal.h>
#include <syslog.h>
#include <unistd.h>

#include "dma.h"

void
bounce(struct qitem *it, const char *reason)
{
	struct queue bounceq;
	char line[1000];
	size_t pos;
	int error;

	/* Don't bounce bounced mails */
	if (it->sender[0] == 0) {
		syslog(LOG_INFO, "can not bounce a bounce message, discarding");
		exit(1);
	}

	bzero(&bounceq, sizeof(bounceq));
	LIST_INIT(&bounceq.queue);
	bounceq.sender = "";
	if (add_recp(&bounceq, it->sender, EXPAND_WILDCARD) != 0)
		goto fail;

	if (newspoolf(&bounceq) != 0)
		goto fail;

	syslog(LOG_ERR, "delivery failed, bouncing as %s", bounceq.id);
	setlogident("%s", bounceq.id);

	error = fprintf(bounceq.mailf,
		"Received: from MAILER-DAEMON\n"
		"\tid %s\n"
		"\tby %s (%s);\n"
		"\t%s\n"
		"X-Original-To: <%s>\n"
		"From: MAILER-DAEMON <>\n"
		"To: %s\n"
		"Subject: Mail delivery failed\n"
		"Message-Id: <%s@%s>\n"
		"Date: %s\n"
		"\n"
		"This is the %s at %s.\n"
		"\n"
		"There was an error delivering your mail to <%s>.\n"
		"\n"
		"%s\n"
		"\n"
		"%s\n"
		"\n",
		bounceq.id,
		hostname(), VERSION,
		rfc822date(),
		it->addr,
		it->sender,
		bounceq.id, hostname(),
		rfc822date(),
		VERSION, hostname(),
		it->addr,
		reason,
		config.features & FULLBOUNCE ?
		    "Original message follows." :
		    "Message headers follow.");
	if (error < 0)
		goto fail;

	if (fseek(it->mailf, 0, SEEK_SET) != 0)
		goto fail;
	if (config.features & FULLBOUNCE) {
		while ((pos = fread(line, 1, sizeof(line), it->mailf)) > 0) {
			if (fwrite(line, 1, pos, bounceq.mailf) != pos)
				goto fail;
		}
	} else {
		while (!feof(it->mailf)) {
			if (fgets(line, sizeof(line), it->mailf) == NULL)
				break;
			if (line[0] == '\n')
				break;
			if (fwrite(line, strlen(line), 1, bounceq.mailf) != 1)
				goto fail;
		}
	}

	if (linkspool(&bounceq) != 0)
		goto fail;
	/* bounce is safe */

	delqueue(it);

	run_queue(&bounceq);
	/* NOTREACHED */

fail:
	syslog(LOG_CRIT, "error creating bounce: %m");
	delqueue(it);
	exit(1);
}

struct parse_state {
	char addr[1000];
	int pos;

	enum {
		NONE = 0,
		START,
		MAIN,
		EOL,
		QUIT
	} state;
	int comment;
	int quote;
	int brackets;
	int esc;
};

/*
 * Simplified RFC2822 header/address parsing.
 * We copy escapes and quoted strings directly, since
 * we have to pass them like this to the mail server anyways.
 * XXX local addresses will need treatment
 */
static int
parse_addrs(struct parse_state *ps, char *s, struct queue *queue)
{
	char *addr;

again:
	switch (ps->state) {
	case NONE:
		return (-1);

	case START:
		/* init our data */
		bzero(ps, sizeof(*ps));

		/* skip over header name */
		while (*s != ':')
			s++;
		s++;
		ps->state = MAIN;
		break;

	case MAIN:
		/* all fine */
		break;

	case EOL:
		switch (*s) {
		case ' ':
		case '\t':
			s++;
			/* continue */
			break;

		default:
			ps->state = QUIT;
			if (ps->pos != 0)
				goto newaddr;
			return (0);
		}

	case QUIT:
		return (0);
	}

	for (; *s != 0; s++) {
		if (ps->esc) {
			ps->esc = 0;

			switch (*s) {
			case '\r':
			case '\n':
				goto err;

			default:
				goto copy;
			}
		}

		if (ps->quote) {
			switch (*s) {
			case '"':
				ps->quote = 0;
				goto copy;

			case '\\':
				ps->esc = 1;
				goto copy;

			case '\r':
			case '\n':
				goto eol;

			default:
				goto copy;
			}
		}

		switch (*s) {
		case '(':
			ps->comment++;
			break;

		case ')':
			if (ps->comment)
				ps->comment--;
			else
				goto err;
			goto skip;

		case '"':
			ps->quote = 1;
			goto copy;

		case '\\':
			ps->esc = 1;
			goto copy;

		case '\r':
		case '\n':
			goto eol;
		}

		if (ps->comment)
			goto skip;

		switch (*s) {
		case ' ':
		case '\t':
			/* ignore whitespace */
			goto skip;

		case '<':
			/* this is the real address now */
			ps->brackets = 1;
			ps->pos = 0;
			goto skip;

		case '>':
			if (!ps->brackets)
				goto err;
			ps->brackets = 0;

			s++;
			goto newaddr;

		case ':':
			/* group - ignore */
			ps->pos = 0;
			goto skip;

		case ',':
		case ';':
			/*
			 * Next address, copy previous one.
			 * However, we might be directly after
			 * a <address>, or have two consecutive
			 * commas.
			 * Skip the comma unless there is
			 * really something to copy.
			 */
			if (ps->pos == 0)
				goto skip;
			s++;
			goto newaddr;

		default:
			goto copy;
		}

copy:
		if (ps->comment)
			goto skip;

		if (ps->pos + 1 == sizeof(ps->addr))
			goto err;
		ps->addr[ps->pos++] = *s;

skip:
		;
	}

eol:
	ps->state = EOL;
	return (0);

err:
	ps->state = QUIT;
	return (-1);

newaddr:
	ps->addr[ps->pos] = 0;
	ps->pos = 0;
	addr = strdup(ps->addr);
	if (addr == NULL)
		errlog(1, NULL);

	if (add_recp(queue, addr, EXPAND_WILDCARD) != 0)
		errlogx(1, "invalid recipient `%s'", addr);

	goto again;
}

int
readmail(struct queue *queue, int nodot, int recp_from_header)
{
	struct parse_state parse_state;
	char line[1000];	/* by RFC2822 */
	size_t linelen;
	size_t error;
	int had_headers = 0;
	int had_from = 0;
	int had_messagid = 0;
	int had_date = 0;
	int had_last_line = 0;
	int nocopy = 0;

	parse_state.state = NONE;

	error = fprintf(queue->mailf,
		"Received: from %s (uid %d)\n"
		"\t(envelope-from %s)\n"
		"\tid %s\n"
		"\tby %s (%s);\n"
		"\t%s\n",
		username, useruid,
		queue->sender,
		queue->id,
		hostname(), VERSION,
		rfc822date());
	if ((ssize_t)error < 0)
		return (-1);

	while (!feof(stdin)) {
		if (fgets(line, sizeof(line) - 1, stdin) == NULL)
			break;
		if (had_last_line)
			errlogx(1, "bad mail input format");
		linelen = strlen(line);
		if (linelen == 0 || line[linelen - 1] != '\n') {
			/*
			 * This line did not end with a newline character.
			 * If we fix it, it better be the last line of
			 * the file.
			 */
			line[linelen] = '\n';
			line[linelen + 1] = 0;
			had_last_line = 1;
		}
		if (!had_headers) {
			/*
			 * Unless this is a continuation, switch of
			 * the Bcc: nocopy flag.
			 */
			if (!(line[0] == ' ' || line[0] == '\t'))
				nocopy = 0;

			if (strprefixcmp(line, "Date:") == 0)
				had_date = 1;
			else if (strprefixcmp(line, "Message-Id:") == 0)
				had_messagid = 1;
			else if (strprefixcmp(line, "From:") == 0)
				had_from = 1;
			else if (strprefixcmp(line, "Bcc:") == 0)
				nocopy = 1;

			if (parse_state.state != NONE) {
				if (parse_addrs(&parse_state, line, queue) < 0) {
					errlogx(1, "invalid address in header\n");
					/* NOTREACHED */
				}
			}

			if (recp_from_header && (
					strprefixcmp(line, "To:") == 0 ||
					strprefixcmp(line, "Cc:") == 0 ||
					strprefixcmp(line, "Bcc:") == 0)) {
				parse_state.state = START;
				if (parse_addrs(&parse_state, line, queue) < 0) {
					errlogx(1, "invalid address in header\n");
					/* NOTREACHED */
				}
			}
		}

		if (strcmp(line, "\n") == 0 && !had_headers) {
			had_headers = 1;
			while (!had_date || !had_messagid || !had_from) {
				if (!had_date) {
					had_date = 1;
					snprintf(line, sizeof(line), "Date: %s\n", rfc822date());
				} else if (!had_messagid) {
					/* XXX msgid, assign earlier and log? */
					had_messagid = 1;
					snprintf(line, sizeof(line), "Message-Id: <%"PRIxMAX".%s.%"PRIxMAX"@%s>\n",
						 (uintmax_t)time(NULL),
						 queue->id,
						 (uintmax_t)random(),
						 hostname());
				} else if (!had_from) {
					had_from = 1;
					snprintf(line, sizeof(line), "From: <%s>\n", queue->sender);
				}
				if (fwrite(line, strlen(line), 1, queue->mailf) != 1)
					return (-1);
			}
			strcpy(line, "\n");
		}
		if (!nodot && linelen == 2 && line[0] == '.')
			break;
		if (!nocopy) {
			if (fwrite(line, strlen(line), 1, queue->mailf) != 1)
				return (-1);
		}
	}

	return (0);
}
Commit	Line	Data
30833a29 SS	1	/*
	2	* Copyright (c) 2008 The DragonFly Project. All rights reserved.
	3	*
	4	* This code is derived from software contributed to The DragonFly Project
	5	* by Simon 'corecode' Schubert <corecode@fs.ei.tum.de>.
	6	*
	7	* Redistribution and use in source and binary forms, with or without
	8	* modification, are permitted provided that the following conditions
	9	* are met:
	10	*
	11	* 1. Redistributions of source code must retain the above copyright
	12	* notice, this list of conditions and the following disclaimer.
	13	* 2. Redistributions in binary form must reproduce the above copyright
	14	* notice, this list of conditions and the following disclaimer in
	15	* the documentation and/or other materials provided with the
	16	* distribution.
	17	* 3. Neither the name of The DragonFly Project nor the names of its
	18	* contributors may be used to endorse or promote products derived
	19	* from this software without specific, prior written permission.
	20	*
	21	* THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
	22	* ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
	23	* LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS
	24	* FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE
	25	* COPYRIGHT HOLDERS OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT,
	26	* INCIDENTAL, SPECIAL, EXEMPLARY OR CONSEQUENTIAL DAMAGES (INCLUDING,
	27	* BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
	28	* LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED
	29	* AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY,
	30	* OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT
	31	* OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
	32	* SUCH DAMAGE.
	33	*/
	34
	35	#include <errno.h>
c8b07ee5 SW	36	#include <inttypes.h>
c8b07ee5 SW	37	#include <signal.h>
30833a29 SS	38	#include <syslog.h>
	39	#include <unistd.h>
	40
	41	#include "dma.h"
	42
	43	void
	44	bounce(struct qitem it, const char reason)
	45	{
	46	struct queue bounceq;
	47	char line[1000];
	48	size_t pos;
	49	int error;
	50
	51	/* Don't bounce bounced mails */
	52	if (it->sender[0] == 0) {
	53	syslog(LOG_INFO, "can not bounce a bounce message, discarding");
	54	exit(1);
	55	}
	56
e50076f8	57	bzero(&bounceq, sizeof(bounceq));
30833a29	58	LIST_INIT(&bounceq.queue);
1c9e6b7b	59	bounceq.sender = "";
c8b07ee5	60	if (add_recp(&bounceq, it->sender, EXPAND_WILDCARD) != 0)
30833a29 SS	61	goto fail;
30833a29 SS	62
1c9e6b7b	63	if (newspoolf(&bounceq) != 0)
30833a29 SS	64	goto fail;
	65
	66	syslog(LOG_ERR, "delivery failed, bouncing as %s", bounceq.id);
	67	setlogident("%s", bounceq.id);
	68
	69	error = fprintf(bounceq.mailf,
	70	"Received: from MAILER-DAEMON\n"
	71	"\tid %s\n"
c8b07ee5	72	"\tby %s (%s);\n"
30833a29 SS	73	"\t%s\n"
	74	"X-Original-To: <%s>\n"
	75	"From: MAILER-DAEMON <>\n"
	76	"To: %s\n"
	77	"Subject: Mail delivery failed\n"
	78	"Message-Id: <%s@%s>\n"
	79	"Date: %s\n"
	80	"\n"
	81	"This is the %s at %s.\n"
	82	"\n"
	83	"There was an error delivering your mail to <%s>.\n"
	84	"\n"
	85	"%s\n"
	86	"\n"
	87	"%s\n"
	88	"\n",
	89	bounceq.id,
	90	hostname(), VERSION,
	91	rfc822date(),
	92	it->addr,
	93	it->sender,
	94	bounceq.id, hostname(),
	95	rfc822date(),
	96	VERSION, hostname(),
	97	it->addr,
	98	reason,
ca259d14	99	config.features & FULLBOUNCE ?
30833a29 SS	100	"Original message follows." :
	101	"Message headers follow.");
	102	if (error < 0)
	103	goto fail;
	104
ebffba26	105	if (fseek(it->mailf, 0, SEEK_SET) != 0)
30833a29	106	goto fail;
ca259d14	107	if (config.features & FULLBOUNCE) {
30833a29 SS	108	while ((pos = fread(line, 1, sizeof(line), it->mailf)) > 0) {
	109	if (fwrite(line, 1, pos, bounceq.mailf) != pos)
	110	goto fail;
	111	}
	112	} else {
	113	while (!feof(it->mailf)) {
	114	if (fgets(line, sizeof(line), it->mailf) == NULL)
	115	break;
	116	if (line[0] == '\n')
	117	break;
	118	if (fwrite(line, strlen(line), 1, bounceq.mailf) != 1)
	119	goto fail;
	120	}
	121	}
	122
1c9e6b7b	123	if (linkspool(&bounceq) != 0)
30833a29 SS	124	goto fail;
	125	/* bounce is safe */
	126
	127	delqueue(it);
	128
	129	run_queue(&bounceq);
	130	/* NOTREACHED */
	131
	132	fail:
	133	syslog(LOG_CRIT, "error creating bounce: %m");
	134	delqueue(it);
	135	exit(1);
	136	}
	137
ff48fce6 SS	138	struct parse_state {
	139	char addr[1000];
	140	int pos;
	141
	142	enum {
	143	NONE = 0,
	144	START,
	145	MAIN,
	146	EOL,
	147	QUIT
	148	} state;
	149	int comment;
	150	int quote;
	151	int brackets;
	152	int esc;
	153	};
	154
	155	/*
	156	* Simplified RFC2822 header/address parsing.
	157	* We copy escapes and quoted strings directly, since
	158	* we have to pass them like this to the mail server anyways.
	159	* XXX local addresses will need treatment
	160	*/
	161	static int
	162	parse_addrs(struct parse_state ps, char s, struct queue *queue)
	163	{
	164	char *addr;
	165
	166	again:
	167	switch (ps->state) {
	168	case NONE:
	169	return (-1);
	170
	171	case START:
	172	/* init our data */
	173	bzero(ps, sizeof(*ps));
	174
	175	/* skip over header name */
	176	while (*s != ':')
	177	s++;
	178	s++;
	179	ps->state = MAIN;
	180	break;
	181
	182	case MAIN:
	183	/* all fine */
	184	break;
	185
	186	case EOL:
	187	switch (*s) {
	188	case ' ':
	189	case '\t':
	190	s++;
	191	/* continue */
	192	break;
	193
	194	default:
	195	ps->state = QUIT;
	196	if (ps->pos != 0)
	197	goto newaddr;
	198	return (0);
	199	}
	200
	201	case QUIT:
202	return (0);
203	}
204
205	for (; *s != 0; s++) {
206	if (ps->esc) {
207	ps->esc = 0;
208
209	switch (*s) {
210	case '\r':
211	case '\n':
212	goto err;
213
214	default:
215	goto copy;
216	}
217	}
218
219	if (ps->quote) {
220	switch (*s) {
221	case '"':
222	ps->quote = 0;
223	goto copy;
224
225	case '\\':
226	ps->esc = 1;
227	goto copy;
228
229	case '\r':
230	case '\n':
231	goto eol;
232
233	default:
234	goto copy;
235	}
236	}
237
238	switch (*s) {
239	case '(':
240	ps->comment++;
241	break;
242
243	case ')':
244	if (ps->comment)
245	ps->comment--;
246	else
247	goto err;
248	goto skip;
249
250	case '"':
251	ps->quote = 1;
252	goto copy;
253
254	case '\\':
255	ps->esc = 1;
256	goto copy;
257
258	case '\r':
259	case '\n':
260	goto eol;
261	}
262
263	if (ps->comment)
264	goto skip;
265
266	switch (*s) {
267	case ' ':
268	case '\t':
269	/* ignore whitespace */
270	goto skip;
271
272	case '<':
c8b07ee5	273	/* this is the real address now */
ff48fce6	274	ps->brackets = 1;
307f84e1	275	ps->pos = 0;
ff48fce6 SS	276	goto skip;
	277
	278	case '>':
	279	if (!ps->brackets)
	280	goto err;
	281	ps->brackets = 0;
	282
	283	s++;
	284	goto newaddr;
	285
	286	case ':':
	287	/* group - ignore */
	288	ps->pos = 0;
	289	goto skip;
	290
	291	case ',':
	292	case ';':
c8b07ee5 SW	293	/*
	294	* Next address, copy previous one.
	295	* However, we might be directly after
	296	* a <address>, or have two consecutive
	297	* commas.
	298	* Skip the comma unless there is
	299	* really something to copy.
	300	*/
	301	if (ps->pos == 0)
	302	goto skip;
ff48fce6 SS	303	s++;
	304	goto newaddr;
	305
	306	default:
	307	goto copy;
	308	}
	309
	310	copy:
	311	if (ps->comment)
	312	goto skip;
	313
	314	if (ps->pos + 1 == sizeof(ps->addr))
	315	goto err;
	316	ps->addr[ps->pos++] = *s;
	317
	318	skip:
	319	;
	320	}
	321
	322	eol:
	323	ps->state = EOL;
	324	return (0);
	325
	326	err:
	327	ps->state = QUIT;
	328	return (-1);
	329
	330	newaddr:
	331	ps->addr[ps->pos] = 0;
	332	ps->pos = 0;
	333	addr = strdup(ps->addr);
	334	if (addr == NULL)
	335	errlog(1, NULL);
	336
c8b07ee5	337	if (add_recp(queue, addr, EXPAND_WILDCARD) != 0)
8378175c	338	errlogx(1, "invalid recipient `%s'", addr);
c8b07ee5	339
ff48fce6 SS	340	goto again;
	341	}
	342
30833a29	343	int
ff48fce6	344	readmail(struct queue *queue, int nodot, int recp_from_header)
30833a29	345	{
ff48fce6	346	struct parse_state parse_state;
30833a29 SS	347	char line[1000]; /* by RFC2822 */
	348	size_t linelen;
	349	size_t error;
	350	int had_headers = 0;
	351	int had_from = 0;
	352	int had_messagid = 0;
	353	int had_date = 0;
c8b07ee5	354	int had_last_line = 0;
ff48fce6 SS	355	int nocopy = 0;
	356
	357	parse_state.state = NONE;
30833a29 SS	358
	359	error = fprintf(queue->mailf,
	360	"Received: from %s (uid %d)\n"
	361	"\t(envelope-from %s)\n"
	362	"\tid %s\n"
c8b07ee5	363	"\tby %s (%s);\n"
30833a29	364	"\t%s\n",
c8b07ee5	365	username, useruid,
1c9e6b7b	366	queue->sender,
30833a29 SS	367	queue->id,
	368	hostname(), VERSION,
	369	rfc822date());
	370	if ((ssize_t)error < 0)
	371	return (-1);
	372
	373	while (!feof(stdin)) {
c8b07ee5	374	if (fgets(line, sizeof(line) - 1, stdin) == NULL)
30833a29	375	break;
c8b07ee5 SW	376	if (had_last_line)
c8b07ee5 SW	377	errlogx(1, "bad mail input format");
30833a29 SS	378	linelen = strlen(line);
30833a29 SS	379	if (linelen == 0 \|\| line[linelen - 1] != '\n') {
c8b07ee5 SW	380	/*
	381	* This line did not end with a newline character.
	382	* If we fix it, it better be the last line of
	383	* the file.
	384	*/
	385	line[linelen] = '\n';
	386	line[linelen + 1] = 0;
	387	had_last_line = 1;
30833a29 SS	388	}
30833a29 SS	389	if (!had_headers) {
ff48fce6 SS	390	/*
	391	* Unless this is a continuation, switch of
	392	* the Bcc: nocopy flag.
	393	*/
	394	if (!(line[0] == ' ' \|\| line[0] == '\t'))
	395	nocopy = 0;
	396
30833a29 SS	397	if (strprefixcmp(line, "Date:") == 0)
	398	had_date = 1;
	399	else if (strprefixcmp(line, "Message-Id:") == 0)
	400	had_messagid = 1;
	401	else if (strprefixcmp(line, "From:") == 0)
	402	had_from = 1;
ff48fce6 SS	403	else if (strprefixcmp(line, "Bcc:") == 0)
	404	nocopy = 1;
	405
	406	if (parse_state.state != NONE) {
	407	if (parse_addrs(&parse_state, line, queue) < 0) {
	408	errlogx(1, "invalid address in header\n");
	409	/* NOTREACHED */
	410	}
	411	}
	412
	413	if (recp_from_header && (
	414	strprefixcmp(line, "To:") == 0 \|\|
	415	strprefixcmp(line, "Cc:") == 0 \|\|
	416	strprefixcmp(line, "Bcc:") == 0)) {
	417	parse_state.state = START;
	418	if (parse_addrs(&parse_state, line, queue) < 0) {
	419	errlogx(1, "invalid address in header\n");
	420	/* NOTREACHED */
	421	}
	422	}
30833a29	423	}
ff48fce6	424
30833a29 SS	425	if (strcmp(line, "\n") == 0 && !had_headers) {
	426	had_headers = 1;
	427	while (!had_date \|\| !had_messagid \|\| !had_from) {
	428	if (!had_date) {
	429	had_date = 1;
	430	snprintf(line, sizeof(line), "Date: %s\n", rfc822date());
	431	} else if (!had_messagid) {
c8b07ee5	432	/* XXX msgid, assign earlier and log? */
30833a29	433	had_messagid = 1;
c8b07ee5 SW	434	snprintf(line, sizeof(line), "Message-Id: <%"PRIxMAX".%s.%"PRIxMAX"@%s>\n",
	435	(uintmax_t)time(NULL),
	436	queue->id,
	437	(uintmax_t)random(),
	438	hostname());
30833a29 SS	439	} else if (!had_from) {
30833a29 SS	440	had_from = 1;
1c9e6b7b	441	snprintf(line, sizeof(line), "From: <%s>\n", queue->sender);
30833a29 SS	442	}
	443	if (fwrite(line, strlen(line), 1, queue->mailf) != 1)
	444	return (-1);
	445	}
	446	strcpy(line, "\n");
	447	}
	448	if (!nodot && linelen == 2 && line[0] == '.')
	449	break;
ff48fce6 SS	450	if (!nocopy) {
	451	if (fwrite(line, strlen(line), 1, queue->mailf) != 1)
	452	return (-1);
	453	}
30833a29 SS	454	}
	455
	456	return (0);
	457	}