8e43f10bce780235f1f94225954262d240c44a73
[dragonfly.git] / libexec / dma / local.c
1 #include <err.h>
2 #include <errno.h>
3 #include <fcntl.h>
4 #include <paths.h>
5 #include <stdint.h>
6 #include <stdio.h>
7 #include <syslog.h>
8 #include <unistd.h>
9
10 #include "dma.h"
11
12 int
13 deliver_local(struct qitem *it, const char **errmsg)
14 {
15         char fn[PATH_MAX+1];
16         char line[1000];
17         size_t linelen;
18         int mbox;
19         int error;
20         off_t mboxlen;
21         time_t now = time(NULL);
22
23         error = snprintf(fn, sizeof(fn), "%s/%s", _PATH_MAILDIR, it->addr);
24         if (error < 0 || (size_t)error >= sizeof(fn)) {
25                 syslog(LOG_NOTICE, "%s: local delivery deferred: %m",
26                        it->queueid);
27                 return (1);
28         }
29
30         /* mailx removes users mailspool file if empty, so open with O_CREAT */
31         mbox = open_locked(fn, O_WRONLY | O_APPEND | O_CREAT);
32         if (mbox < 0) {
33                 syslog(LOG_NOTICE, "%s: local delivery deferred: can not open `%s': %m",
34                        it->queueid, fn);
35                 return (1);
36         }
37         mboxlen = lseek(mbox, 0, SEEK_CUR);
38
39         if (fseek(it->mailf, it->hdrlen, SEEK_SET) != 0) {
40                 syslog(LOG_NOTICE, "%s: local delivery deferred: can not seek: %m",
41                        it->queueid);
42                 return (1);
43         }
44
45         error = snprintf(line, sizeof(line), "From %s\t%s", it->sender, ctime(&now));
46         if (error < 0 || (size_t)error >= sizeof(line)) {
47                 syslog(LOG_NOTICE, "%s: local delivery deferred: can not write header: %m",
48                        it->queueid);
49                 return (1);
50         }
51         if (write(mbox, line, error) != error)
52                 goto wrerror;
53
54         while (!feof(it->mailf)) {
55                 if (fgets(line, sizeof(line), it->mailf) == NULL)
56                         break;
57                 linelen = strlen(line);
58                 if (linelen == 0 || line[linelen - 1] != '\n') {
59                         syslog(LOG_CRIT, "%s: local delivery failed: corrupted queue file",
60                                it->queueid);
61                         *errmsg = "corrupted queue file";
62                         error = -1;
63                         goto chop;
64                 }
65
66                 if (strncmp(line, "From ", 5) == 0) {
67                         const char *gt = ">";
68
69                         if (write(mbox, gt, 1) != 1)
70                                 goto wrerror;
71                 }
72                 if ((size_t)write(mbox, line, linelen) != linelen)
73                         goto wrerror;
74         }
75         line[0] = '\n';
76         if (write(mbox, line, 1) != 1)
77                 goto wrerror;
78         close(mbox);
79         return (0);
80
81 wrerror:
82         syslog(LOG_ERR, "%s: local delivery failed: write error: %m",
83                it->queueid);
84         error = 1;
85 chop:
86         if (ftruncate(mbox, mboxlen) != 0)
87                 syslog(LOG_WARNING, "%s: error recovering mbox `%s': %m",
88                        it->queueid, fn);
89         close(mbox);
90         return (error);
91 }