2 * Copyright (c) 2008 The DragonFly Project. All rights reserved.
4 * This code is derived from software contributed to The DragonFly Project
5 * by Simon 'corecode' Schubert <corecode@fs.ei.tum.de>.
7 * Redistribution and use in source and binary forms, with or without
8 * modification, are permitted provided that the following conditions
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
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.
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
35 #include <sys/param.h>
36 #include <sys/queue.h>
38 #include <sys/types.h>
59 static void deliver(struct qitem *);
61 struct aliases aliases = LIST_HEAD_INITIALIZER(aliases);
62 struct strlist tmpfs = SLIST_HEAD_INITIALIZER(tmpfs);
63 struct virtusers virtusers = LIST_HEAD_INITIALIZER(virtusers);
64 struct authusers authusers = LIST_HEAD_INITIALIZER(authusers);
66 const char *logident_base;
68 static int daemonize = 1;
70 struct config config = {
73 .aliases = "/var/mail/aliases",
74 .spooldir = "/var/spool/dma",
85 set_from(struct queue *queue, const char *osender)
90 if ((config.features & VIRTUAL) != 0) {
91 SLIST_FOREACH(v, &virtusers, next) {
92 if (strcmp(v->login, username) == 0) {
93 sender = strdup(v->address);
102 sender = strdup(osender);
106 if (asprintf(&sender, "%s@%s", username, hostname()) <= 0)
110 if (strchr(sender, '\n') != NULL) {
116 queue->sender = sender;
123 yyin = fopen(config.aliases, "r");
126 * Non-existing aliases file is not a fatal error
130 /* Other problems are. */
134 return (-1); /* fatal error, probably malloc() */
140 add_recp(struct queue *queue, const char *str, int expand)
142 struct qitem *it, *tit;
149 it = calloc(1, sizeof(*it));
152 it->addr = strdup(str);
153 if (it->addr == NULL)
156 it->sender = queue->sender;
157 host = strrchr(it->addr, '@');
159 (strcmp(host + 1, hostname()) == 0 ||
160 strcmp(host + 1, "localhost") == 0)) {
163 LIST_FOREACH(tit, &queue->queue, next) {
164 /* weed out duplicate dests */
165 if (strcmp(tit->addr, it->addr) == 0) {
171 LIST_INSERT_HEAD(&queue->queue, it, next);
172 if (strrchr(it->addr, '@') == NULL) {
175 LIST_FOREACH(al, &aliases, next) {
176 if (strcmp(al->alias, it->addr) != 0)
178 SLIST_FOREACH(sit, &al->dests, next) {
179 if (add_recp(queue, sit->str, 1) != 0)
185 LIST_REMOVE(it, next);
187 /* Local destination, check */
188 pw = getpwnam(it->addr);
191 /* XXX read .forward */
207 static struct qitem *
208 go_background(struct queue *queue)
214 if (daemonize && daemon(0, 0) != 0) {
215 syslog(LOG_ERR, "can not daemonize: %m");
220 bzero(&sa, sizeof(sa));
221 sa.sa_flags = SA_NOCLDWAIT;
222 sa.sa_handler = SIG_IGN;
223 sigaction(SIGCHLD, &sa, NULL);
225 LIST_FOREACH(it, &queue->queue, next) {
226 /* No need to fork for the last dest */
227 if (LIST_NEXT(it, next) == NULL)
233 syslog(LOG_ERR, "can not fork: %m");
241 * return and deliver mail
245 * If necessary, acquire the queue and * mail files.
246 * If this fails, we probably were raced by another
249 setlogident("%s", it->queueid);
250 if (acquirespool(it) < 0)
252 dropspool(queue, it);
265 syslog(LOG_CRIT, "reached dead code");
270 deliver(struct qitem *it)
273 unsigned int backoff = MIN_RETRY;
274 const char *errmsg = "unknown bounce reason";
279 syslog(LOG_INFO, "trying delivery");
282 error = deliver_remote(it, &errmsg);
284 error = deliver_local(it, &errmsg);
289 syslog(LOG_INFO, "delivery successful");
293 if (stat(it->queuefn, &st) != 0) {
294 syslog(LOG_ERR, "lost queue file `%s'", it->queuefn);
297 if (gettimeofday(&now, NULL) == 0 &&
298 (now.tv_sec - st.st_mtimespec.tv_sec > MAX_TIMEOUT)) {
299 asprintf(__DECONST(void *, &errmsg),
300 "Could not deliver for the last %d seconds. Giving up.",
306 if (backoff > MAX_RETRY)
321 run_queue(struct queue *queue)
325 if (LIST_EMPTY(&queue->queue))
328 it = go_background(queue);
334 show_queue(struct queue *queue)
337 int locked = 0; /* XXX */
339 if (LIST_EMPTY(&queue->queue)) {
340 printf("Mail queue is empty\n");
344 LIST_FOREACH(it, &queue->queue, next) {
345 printf("ID\t: %s%s\n"
350 it->sender, it->addr);
352 if (LIST_NEXT(it, next) != NULL)
361 * - use group permissions
362 * - proper sysexit codes
366 main(int argc, char **argv)
371 int nodot = 0, doqueue = 0, showq = 0, queue_only = 0;
372 int recp_from_header = 0;
376 bzero(&queue, sizeof(queue));
377 LIST_INIT(&queue.queue);
379 if (strcmp(argv[0], "mailq") == 0) {
383 errx(1, "invalid arguments");
388 while ((ch = getopt(argc, argv, ":A:b:B:C:d:Df:F:h:iL:N:no:O:q:r:R:tUV:vX:")) != -1) {
391 /* -AX is being ignored, except for -A{c,m} */
392 if (optarg[0] == 'c' || optarg[0] == 'm') {
395 /* else FALLTRHOUGH */
397 /* -bX is being ignored, except for -bp */
398 if (optarg[0] == 'p') {
401 } else if (optarg[0] == 'q') {
405 /* else FALLTRHOUGH */
410 logident_base = optarg;
418 recp_from_header = 1;
422 /* -oX is being ignored, except for -oi */
423 if (optarg[0] != 'i')
425 /* else FALLTRHOUGH */
436 /* Ignored options */
459 fprintf(stderr, "invalid argument: `-%c'\n", optopt);
467 if (argc != 0 && (showq || doqueue))
468 errx(1, "sending mail and queue operations are mutually exclusive");
470 if (showq + doqueue > 1)
471 errx(1, "conflicting queue operations");
474 if (logident_base == NULL)
475 logident_base = "dma";
479 /* XXX fork root here */
481 parse_conf(CONF_PATH);
483 if (config.features & VIRTUAL) {
484 if (config.virtualpath == NULL)
485 errlogx(1, "no virtuser file specified, but VIRTUAL configured");
486 parse_virtuser(config.virtualpath);
489 if (config.authpath != NULL)
490 parse_authfile(config.authpath);
493 if (load_queue(&queue) < 0)
494 errlog(1, "can not load queue");
500 if (load_queue(&queue) < 0)
501 errlog(1, "can not load queue");
506 if (read_aliases() != 0)
507 errlog(1, "can not read aliases file `%s'", config.aliases);
509 if ((sender = set_from(&queue, sender)) == NULL)
512 if (newspoolf(&queue) != 0)
513 errlog(1, "can not create temp file");
515 setlogident("%s", queue.id);
517 for (i = 0; i < argc; i++) {
518 if (add_recp(&queue, argv[i], 1) != 0)
519 errlogx(1, "invalid recipient `%s'", argv[i]);
522 if (LIST_EMPTY(&queue.queue) && !recp_from_header)
523 errlogx(1, "no recipients");
525 if (readmail(&queue, nodot, recp_from_header) != 0)
526 errlog(1, "can not read mail");
528 if (LIST_EMPTY(&queue.queue))
529 errlogx(1, "no recipients");
531 if (linkspool(&queue) != 0)
532 errlog(1, "can not create spools");
534 /* From here on the mail is safe. */
536 if (config.features & DEFER || queue_only)