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