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/types.h>
37 #include <sys/queue.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_mtim
.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
)