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 }