dma(8): Upgrade to v0.7.
[dragonfly.git] / libexec / dma / mail.c
CommitLineData
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>
37#include <signal.h>
30833a29
SS
38#include <syslog.h>
39#include <unistd.h>
40
41#include "dma.h"
42
43void
44bounce(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;
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
132fail:
133 syslog(LOG_CRIT, "error creating bounce: %m");
134 delqueue(it);
135 exit(1);
136}
137
ff48fce6
SS
138struct 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 */
161static int
162parse_addrs(struct parse_state *ps, char *s, struct queue *queue)
163{
164 char *addr;
165
166again:
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
310copy:
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
318skip:
319 ;
320 }
321
322eol:
323 ps->state = EOL;
324 return (0);
325
326err:
327 ps->state = QUIT;
328 return (-1);
329
330newaddr:
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 343int
ff48fce6 344readmail(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)
377 errlogx(1, "bad mail input format");
30833a29
SS
378 linelen = strlen(line);
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 }
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) {
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}