LDADD= -lssl -lcrypto
PROG= dma
-SRCS= base64.c conf.c crypto.c net.c dma.c aliases_scan.l aliases_parse.y
+SRCS= base64.c conf.c crypto.c net.c dma.c aliases_scan.l aliases_parse.y spool.c local.c
MAN= dma.8
BINOWN= root
#define DP ": \t\n"
#define EQS " \t\n"
-extern struct virtusers virtusers;
-extern struct authusers authusers;
/*
* Remove trailing \n's
* Check for bad things[TM]
*/
int
-parse_conf(const char *config_path, struct config *config)
+parse_conf(const char *config_path)
{
char *word;
char *data;
#include "dma.h"
-extern struct config *config;
-
static int
init_cert_file(struct qitem *it, SSL_CTX *ctx, const char *path)
{
static void deliver(struct qitem *);
-static int add_recp(struct queue *, const char *, const char *, int);
struct aliases aliases = LIST_HEAD_INITIALIZER(aliases);
-static struct strlist tmpfs = SLIST_HEAD_INITIALIZER(tmpfs);
+struct strlist tmpfs = SLIST_HEAD_INITIALIZER(tmpfs);
struct virtusers virtusers = LIST_HEAD_INITIALIZER(virtusers);
struct authusers authusers = LIST_HEAD_INITIALIZER(authusers);
static int daemonize = 1;
struct config *config;
static const char *username;
static uid_t uid;
-static struct strlist seenmsg[16][16];
-char *
+const char *
hostname(void)
{
static char name[MAXHOSTNAMELEN+1];
return (0);
}
-static int
+int
add_recp(struct queue *queue, const char *str, const char *sender, int expand)
{
struct qitem *it, *tit;
}
}
-static int
-gentempf(struct queue *queue)
+int
+open_locked(const char *fname, int flags, ...)
{
- char fn[PATH_MAX+1];
- struct stritem *t;
- int fd;
+ int mode = 0;
- if (snprintf(fn, sizeof(fn), "%s/%s", config->spooldir, "tmp_XXXXXXXXXX") <= 0)
- return (-1);
- fd = mkstemp(fn);
- if (fd < 0)
- return (-1);
- if (flock(fd, LOCK_EX) == -1)
- return (-1);
- queue->mailfd = fd;
- queue->tmpf = strdup(fn);
- if (queue->tmpf == NULL) {
- unlink(fn);
- return (-1);
- }
- t = malloc(sizeof(*t));
- if (t != NULL) {
- t->str = queue->tmpf;
- SLIST_INSERT_HEAD(&tmpfs, t, next);
+ if (flags & O_CREAT) {
+ va_list ap;
+ va_start(ap, flags);
+ mode = va_arg(ap, int);
+ va_end(ap);
}
- return (0);
-}
-static int
-open_locked(const char *fname, int flags)
-{
#ifndef O_EXLOCK
int fd, save_errno;
- fd = open(fname, flags, 0);
+ fd = open(fname, flags, mode);
if (fd < 0)
return(fd);
if (flock(fd, LOCK_EX|((flags & O_NONBLOCK)? LOCK_NB: 0)) < 0) {
}
return(fd);
#else
- return(open(fname, flags|O_EXLOCK));
+ return(open(fname, flags|O_EXLOCK, mode));
#endif
}
-/*
- * spool file format:
- *
- * envelope-from
- * queue-id1 envelope-to1
- * queue-id2 envelope-to2
- * ...
- * <empty line>
- * mail data
- *
- * queue ids are unique, formed from the inode of the spool file
- * and a unique identifier.
- */
-static int
-preparespool(struct queue *queue, const char *sender)
-{
- char line[1000]; /* by RFC2822 */
- struct stat st;
- int error;
- struct qitem *it;
- FILE *queuef;
- off_t hdrlen;
-
- error = snprintf(line, sizeof(line), "%s\n", sender);
- if (error < 0 || (size_t)error >= sizeof(line)) {
- errno = E2BIG;
- return (-1);
- }
- if (write(queue->mailfd, line, error) != error)
- return (-1);
-
- queuef = fdopen(queue->mailfd, "r+");
- if (queuef == NULL)
- return (-1);
-
- /*
- * Assign queue id to each dest.
- */
- if (fstat(queue->mailfd, &st) != 0)
- return (-1);
- queue->id = st.st_ino;
-
- syslog(LOG_INFO, "%"PRIxMAX": new mail from user=%s uid=%d envelope_from=<%s>",
- queue->id, username, uid, sender);
-
- LIST_FOREACH(it, &queue->queue, next) {
- if (asprintf(&it->queueid, "%"PRIxMAX".%"PRIxPTR,
- queue->id, (uintptr_t)it) <= 0)
- return (-1);
- if (asprintf(&it->queuefn, "%s/%s",
- config->spooldir, it->queueid) <= 0)
- return (-1);
- /* File may not exist yet */
- if (stat(it->queuefn, &st) == 0)
- return (-1);
- it->queuef = queuef;
- error = snprintf(line, sizeof(line), "%s %s\n",
- it->queueid, it->addr);
- if (error < 0 || (size_t)error >= sizeof(line))
- return (-1);
- if (write(queue->mailfd, line, error) != error)
- return (-1);
-
- syslog(LOG_INFO, "%"PRIxMAX": mail to=<%s> queued as %s",
- queue->id, it->addr, it->queueid);
- }
- line[0] = '\n';
- if (write(queue->mailfd, line, 1) != 1)
- return (-1);
-
- hdrlen = lseek(queue->mailfd, 0, SEEK_CUR);
- LIST_FOREACH(it, &queue->queue, next) {
- it->hdrlen = hdrlen;
- }
- return (0);
-}
-
static char *
rfc822date(void)
{
return (0);
}
-static int
-linkspool(struct queue *queue)
-{
- struct qitem *it;
-
- LIST_FOREACH(it, &queue->queue, next) {
- if (link(queue->tmpf, it->queuefn) != 0)
- goto delfiles;
- }
- unlink(queue->tmpf);
- return (0);
-
-delfiles:
- LIST_FOREACH(it, &queue->queue, next) {
- unlink(it->queuefn);
- }
- return (-1);
-}
-
static struct qitem *
go_background(struct queue *queue)
{
struct sigaction sa;
struct qitem *it;
- FILE *newqf;
pid_t pid;
if (daemonize && daemon(0, 0) != 0) {
*
* return and deliver mail
*/
- /*
- * We have to prevent sharing of fds between children, so
- * we have to re-open the queue file.
- */
- newqf = fopen(it->queuefn, "r");
- if (newqf == NULL) {
- syslog(LOG_ERR, "can not re-open queue file `%s': %m",
- it->queuefn);
- exit(1);
- }
- fclose(it->queuef);
- it->queuef = newqf;
return (it);
default:
LIST_INIT(&bounceq.queue);
if (add_recp(&bounceq, it->sender, "", 1) != 0)
goto fail;
- if (gentempf(&bounceq) != 0)
+ if (newspoolf(&bounceq, "") != 0)
goto fail;
- if (preparespool(&bounceq, "") != 0)
- goto fail;
-
bit = LIST_FIRST(&bounceq.queue);
- error = fprintf(bit->queuef,
+ error = fprintf(bit->mailf,
"Received: from MAILER-DAEMON\n"
"\tid %"PRIxMAX"\n"
"\tby %s (%s)\n"
"Message headers follow.");
if (error < 0)
goto fail;
- if (fflush(bit->queuef) != 0)
+ if (fflush(bit->mailf) != 0)
goto fail;
- if (fseek(it->queuef, it->hdrlen, SEEK_SET) != 0)
+ if (fseek(it->mailf, it->hdrlen, SEEK_SET) != 0)
goto fail;
if (config->features & FULLBOUNCE) {
- while ((pos = fread(line, 1, sizeof(line), it->queuef)) > 0) {
+ while ((pos = fread(line, 1, sizeof(line), it->mailf)) > 0) {
if ((size_t)write(bounceq.mailfd, line, pos) != pos)
goto fail;
}
} else {
- while (!feof(it->queuef)) {
- if (fgets(line, sizeof(line), it->queuef) == NULL)
+ while (!feof(it->mailf)) {
+ if (fgets(line, sizeof(line), it->mailf) == NULL)
break;
if (line[0] == '\n')
break;
goto fail;
/* bounce is safe */
- unlink(it->queuefn);
- fclose(it->queuef);
+ delqueue(it);
bit = go_background(&bounceq);
deliver(bit);
fail:
syslog(LOG_CRIT, "%s: error creating bounce: %m", it->queueid);
- unlink(it->queuefn);
+ delqueue(it);
exit(1);
}
-static int
-deliver_local(struct qitem *it, const char **errmsg)
-{
- char fn[PATH_MAX+1];
- char line[1000];
- size_t linelen;
- int mbox;
- int error;
- off_t mboxlen;
- time_t now = time(NULL);
-
- error = snprintf(fn, sizeof(fn), "%s/%s", _PATH_MAILDIR, it->addr);
- if (error < 0 || (size_t)error >= sizeof(fn)) {
- syslog(LOG_NOTICE, "%s: local delivery deferred: %m",
- it->queueid);
- return (1);
- }
-
- /* mailx removes users mailspool file if empty, so open with O_CREAT */
- mbox = open_locked(fn, O_WRONLY | O_APPEND | O_CREAT);
- if (mbox < 0) {
- syslog(LOG_NOTICE, "%s: local delivery deferred: can not open `%s': %m",
- it->queueid, fn);
- return (1);
- }
- mboxlen = lseek(mbox, 0, SEEK_CUR);
-
- if (fseek(it->queuef, it->hdrlen, SEEK_SET) != 0) {
- syslog(LOG_NOTICE, "%s: local delivery deferred: can not seek: %m",
- it->queueid);
- return (1);
- }
-
- error = snprintf(line, sizeof(line), "From %s\t%s", it->sender, ctime(&now));
- if (error < 0 || (size_t)error >= sizeof(line)) {
- syslog(LOG_NOTICE, "%s: local delivery deferred: can not write header: %m",
- it->queueid);
- return (1);
- }
- if (write(mbox, line, error) != error)
- goto wrerror;
-
- while (!feof(it->queuef)) {
- if (fgets(line, sizeof(line), it->queuef) == NULL)
- break;
- linelen = strlen(line);
- if (linelen == 0 || line[linelen - 1] != '\n') {
- syslog(LOG_CRIT, "%s: local delivery failed: corrupted queue file",
- it->queueid);
- *errmsg = "corrupted queue file";
- error = -1;
- goto chop;
- }
-
- if (strncmp(line, "From ", 5) == 0) {
- const char *gt = ">";
-
- if (write(mbox, gt, 1) != 1)
- goto wrerror;
- }
- if ((size_t)write(mbox, line, linelen) != linelen)
- goto wrerror;
- }
- line[0] = '\n';
- if (write(mbox, line, 1) != 1)
- goto wrerror;
- close(mbox);
- return (0);
-
-wrerror:
- syslog(LOG_ERR, "%s: local delivery failed: write error: %m",
- it->queueid);
- error = 1;
-chop:
- if (ftruncate(mbox, mboxlen) != 0)
- syslog(LOG_WARNING, "%s: error recovering mbox `%s': %m",
- it->queueid, fn);
- close(mbox);
- return (error);
-}
-
static void
deliver(struct qitem *it)
{
switch (error) {
case 0:
- unlink(it->queuefn);
+ delqueue(it);
syslog(LOG_INFO, "%s: delivery successful",
it->queueid);
exit(0);
/* NOTREACHED */
}
-static int
-c2x(char c)
-{
- if (c <= '9')
- return (c - '0');
- else if (c <= 'F')
- return (c - 'A' + 10);
- else
- return (c - 'a' + 10);
-}
-
-static void
-seen_init(void)
-{
- int i, j;
-
- for (i = 0; i < 16; i++)
- for (j = 0; j < 16; j++)
- SLIST_INIT(&seenmsg[i][j]);
-}
-
-static int
-seen(const char *msgid)
-{
- const char *p;
- size_t len;
- int i, j;
- struct stritem *t;
-
- p = strchr(msgid, '.');
- if (p == NULL)
- return (0);
- len = p - msgid;
- if (len >= 2) {
- i = c2x(msgid[len - 2]);
- j = c2x(msgid[len - 1]);
- } else if (len == 1) {
- i = c2x(msgid[0]);
- j = 0;
- } else {
- i = j = 0;
- }
- if (i < 0 || i >= 16 || j < 0 || j >= 16)
- errx(1, "INTERNAL ERROR: bad seen code for msgid %s", msgid);
- SLIST_FOREACH(t, &seenmsg[i][j], next)
- if (!strncmp(t->str, msgid, len))
- return (1);
- t = malloc(sizeof(*t));
- if (t == NULL)
- errx(1, "Could not allocate %lu bytes",
- (unsigned long)(sizeof(*t)));
- t->str = strdup(msgid);
- if (t->str == NULL)
- errx(1, "Could not duplicate msgid %s", msgid);
- SLIST_INSERT_HEAD(&seenmsg[i][j], t, next);
- return (0);
-}
-
-static void
-load_queue(struct queue *queue, int ignorelock)
-{
- struct stat st;
- struct qitem *it;
- //struct queue queue, itmqueue;
- struct queue itmqueue;
- DIR *spooldir;
- struct dirent *de;
- char line[1000];
- char *fn;
- FILE *queuef;
- char *sender;
- char *addr;
- char *queueid;
- char *queuefn;
- off_t hdrlen;
- int fd, locked, seenit;
-
- LIST_INIT(&queue->queue);
-
- spooldir = opendir(config->spooldir);
- if (spooldir == NULL)
- err(1, "reading queue");
-
- seen_init();
- while ((de = readdir(spooldir)) != NULL) {
- sender = NULL;
- queuef = NULL;
- queueid = NULL;
- queuefn = NULL;
- fn = NULL;
- LIST_INIT(&itmqueue.queue);
-
- /* ignore temp files */
- if (strncmp(de->d_name, "tmp_", 4) == 0 ||
- de->d_type != DT_REG)
- continue;
- if (asprintf(&queuefn, "%s/%s", config->spooldir, de->d_name) < 0)
- goto fail;
- seenit = seen(de->d_name);
- locked = 0;
- fd = open_locked(queuefn, O_RDONLY|O_NONBLOCK);
- if (fd < 0) {
- /* Ignore locked files */
- if (errno != EWOULDBLOCK)
- goto skip_item;
- if (!ignorelock || seenit)
- continue;
- fd = open(queuefn, O_RDONLY);
- if (fd < 0)
- goto skip_item;
- locked = 1;
- }
-
- queuef = fdopen(fd, "r");
- if (queuef == NULL)
- goto skip_item;
- if (fgets(line, sizeof(line), queuef) == NULL ||
- line[0] == 0)
- goto skip_item;
- line[strlen(line) - 1] = 0; /* chop newline */
- sender = strdup(line);
- if (sender == NULL)
- goto skip_item;
-
- for (;;) {
- if (fgets(line, sizeof(line), queuef) == NULL ||
- line[0] == 0)
- goto skip_item;
- if (line[0] == '\n')
- break;
- line[strlen(line) - 1] = 0;
- queueid = strdup(line);
- if (queueid == NULL)
- goto skip_item;
- addr = strchr(queueid, ' ');
- if (addr == NULL)
- goto skip_item;
- *addr++ = 0;
- if (fn != NULL)
- free(fn);
- if (asprintf(&fn, "%s/%s", config->spooldir, queueid) < 0)
- goto skip_item;
- /* Item has already been delivered? */
- if (stat(fn, &st) != 0)
- continue;
- if (add_recp(&itmqueue, addr, sender, 0) != 0)
- goto skip_item;
- it = LIST_FIRST(&itmqueue.queue);
- it->queuef = queuef;
- it->queueid = queueid;
- it->queuefn = fn;
- it->locked = locked;
- fn = NULL;
- }
- if (LIST_EMPTY(&itmqueue.queue)) {
- warnx("queue file without items: `%s'", queuefn);
- goto skip_item2;
- }
- hdrlen = ftell(queuef);
- while ((it = LIST_FIRST(&itmqueue.queue)) != NULL) {
- it->hdrlen = hdrlen;
- LIST_REMOVE(it, next);
- LIST_INSERT_HEAD(&queue->queue, it, next);
- }
- continue;
-
-skip_item:
- warn("reading queue: `%s'", queuefn);
-skip_item2:
- if (sender != NULL)
- free(sender);
- if (queuefn != NULL)
- free(queuefn);
- if (fn != NULL)
- free(fn);
- if (queueid != NULL)
- free(queueid);
- close(fd);
- }
- closedir(spooldir);
- return;
-
-fail:
- err(1, "reading queue");
-}
-
static void
run_queue(struct queue *queue)
{
if (config == NULL)
err(1, NULL);
- if (parse_conf(CONF_PATH, config) < 0) {
+ if (parse_conf(CONF_PATH) < 0) {
free(config);
err(1, "can not read config file");
}
if (LIST_EMPTY(&queue.queue))
errx(1, "no recipients");
- if (gentempf(&queue) != 0)
+ if (newspoolf(&queue, sender) != 0)
err(1, "can not create temp file");
- if (preparespool(&queue, sender) != 0)
- err(1, "can not create spools (1)");
-
if (readmail(&queue, sender, nodot) != 0)
err(1, "can not read mail");
if (linkspool(&queue) != 0)
- err(1, "can not create spools (2)");
+ err(1, "can not create spools");
/* From here on the mail is safe. */
#include <openssl/ssl.h>
#include <sys/queue.h>
-#include <stdint.h>
-#include <stdio.h>
#ifndef __unused
#ifdef __GNUC__
#define INSECURE 0x020 /* Allow plain login w/o encryption */
#define FULLBOUNCE 0x040 /* Bounce the full message */
+#ifndef CONF_PATH
#define CONF_PATH "/etc/dma/dma.conf" /* Default path to dma.conf */
+#endif
struct stritem {
SLIST_ENTRY(stritem) next;
const char *sender;
char *addr;
char *queuefn;
+ char *mailfn;
char *queueid;
- FILE *queuef;
+ FILE *mailf;
+ int queuefd;
off_t hdrlen;
int remote;
int locked;
};
SLIST_HEAD(authusers, authuser);
+
+/* global variables */
extern struct aliases aliases;
+extern struct config *config;
+extern struct strlist tmpfs;
+extern struct virtusers virtusers;
+extern struct authusers authusers;
extern char neterr[BUF_SIZE];
/* aliases_parse.y */
-extern int yyparse(void);
+int yyparse(void);
extern FILE *yyin;
/* conf.c */
-extern void trim_line(char *);
-extern int parse_conf(const char *, struct config *);
-extern int parse_virtuser(const char *);
-extern int parse_authfile(const char *);
+void trim_line(char *);
+int parse_conf(const char *);
+int parse_virtuser(const char *);
+int parse_authfile(const char *);
/* crypto.c */
-extern void hmac_md5(unsigned char *, int, unsigned char *, int, caddr_t);
-extern int smtp_auth_md5(struct qitem *, int, char *, char *);
-extern int smtp_init_crypto(struct qitem *, int, int);
+void hmac_md5(unsigned char *, int, unsigned char *, int, caddr_t);
+int smtp_auth_md5(struct qitem *, int, char *, char *);
+int smtp_init_crypto(struct qitem *, int, int);
/* net.c */
-extern char *ssl_errstr(void);
-extern int read_remote(int, int, char *);
-extern ssize_t send_remote_command(int, const char*, ...);
-extern int deliver_remote(struct qitem *, const char **);
+char *ssl_errstr(void);
+int read_remote(int, int, char *);
+ssize_t send_remote_command(int, const char*, ...);
+int deliver_remote(struct qitem *, const char **);
/* base64.c */
-extern int base64_encode(const void *, int, char **);
-extern int base64_decode(const char *, void *);
+int base64_encode(const void *, int, char **);
+int base64_decode(const char *, void *);
/* dma.c */
-extern char * hostname(void);
+int open_locked(const char *, int, ...);
+int add_recp(struct queue *, const char *, const char *, int);
+const char *hostname(void);
+
+/* spool.c */
+int newspoolf(struct queue *, const char *);
+int linkspool(struct queue *);
+void load_queue(struct queue *, int);
+void delqueue(struct qitem *);
+
+/* local.c */
+int deliver_local(struct qitem *, const char **errmsg);
#endif
--- /dev/null
+#include <err.h>
+#include <errno.h>
+#include <fcntl.h>
+#include <paths.h>
+#include <stdint.h>
+#include <stdio.h>
+#include <syslog.h>
+#include <unistd.h>
+
+#include "dma.h"
+
+int
+deliver_local(struct qitem *it, const char **errmsg)
+{
+ char fn[PATH_MAX+1];
+ char line[1000];
+ size_t linelen;
+ int mbox;
+ int error;
+ off_t mboxlen;
+ time_t now = time(NULL);
+
+ error = snprintf(fn, sizeof(fn), "%s/%s", _PATH_MAILDIR, it->addr);
+ if (error < 0 || (size_t)error >= sizeof(fn)) {
+ syslog(LOG_NOTICE, "%s: local delivery deferred: %m",
+ it->queueid);
+ return (1);
+ }
+
+ /* mailx removes users mailspool file if empty, so open with O_CREAT */
+ mbox = open_locked(fn, O_WRONLY | O_APPEND | O_CREAT);
+ if (mbox < 0) {
+ syslog(LOG_NOTICE, "%s: local delivery deferred: can not open `%s': %m",
+ it->queueid, fn);
+ return (1);
+ }
+ mboxlen = lseek(mbox, 0, SEEK_CUR);
+
+ if (fseek(it->mailf, it->hdrlen, SEEK_SET) != 0) {
+ syslog(LOG_NOTICE, "%s: local delivery deferred: can not seek: %m",
+ it->queueid);
+ return (1);
+ }
+
+ error = snprintf(line, sizeof(line), "From %s\t%s", it->sender, ctime(&now));
+ if (error < 0 || (size_t)error >= sizeof(line)) {
+ syslog(LOG_NOTICE, "%s: local delivery deferred: can not write header: %m",
+ it->queueid);
+ return (1);
+ }
+ if (write(mbox, line, error) != error)
+ goto wrerror;
+
+ while (!feof(it->mailf)) {
+ if (fgets(line, sizeof(line), it->mailf) == NULL)
+ break;
+ linelen = strlen(line);
+ if (linelen == 0 || line[linelen - 1] != '\n') {
+ syslog(LOG_CRIT, "%s: local delivery failed: corrupted queue file",
+ it->queueid);
+ *errmsg = "corrupted queue file";
+ error = -1;
+ goto chop;
+ }
+
+ if (strncmp(line, "From ", 5) == 0) {
+ const char *gt = ">";
+
+ if (write(mbox, gt, 1) != 1)
+ goto wrerror;
+ }
+ if ((size_t)write(mbox, line, linelen) != linelen)
+ goto wrerror;
+ }
+ line[0] = '\n';
+ if (write(mbox, line, 1) != 1)
+ goto wrerror;
+ close(mbox);
+ return (0);
+
+wrerror:
+ syslog(LOG_ERR, "%s: local delivery failed: write error: %m",
+ it->queueid);
+ error = 1;
+chop:
+ if (ftruncate(mbox, mboxlen) != 0)
+ syslog(LOG_WARNING, "%s: error recovering mbox `%s': %m",
+ it->queueid, fn);
+ close(mbox);
+ return (error);
+}
#include "dma.h"
-extern struct config *config;
-extern struct authusers authusers;
static jmp_buf timeout_alarm;
char neterr[BUF_SIZE];
send_remote_command(fd, "DATA");
READ_REMOTE_CHECK("DATA", 3);
- if (fseek(it->queuef, it->hdrlen, SEEK_SET) != 0) {
+ if (fseek(it->mailf, it->hdrlen, SEEK_SET) != 0) {
syslog(LOG_ERR, "%s: remote delivery deferred: cannot seek: %s",
it->queueid, neterr);
return (1);
}
error = 0;
- while (!feof(it->queuef)) {
- if (fgets(line, sizeof(line), it->queuef) == NULL)
+ while (!feof(it->mailf)) {
+ if (fgets(line, sizeof(line), it->mailf) == NULL)
break;
linelen = strlen(line);
if (linelen == 0 || line[linelen - 1] != '\n') {
--- /dev/null
+/*
+ * Copyright (c) 2008 The DragonFly Project. All rights reserved.
+ *
+ * This code is derived from software contributed to The DragonFly Project
+ * by Simon 'corecode' Schubert <corecode@fs.ei.tum.de>.
+ *
+ * Redistribution and use in source and binary forms, with or without
+ * modification, are permitted provided that the following conditions
+ * are met:
+ *
+ * 1. Redistributions of source code must retain the above copyright
+ * notice, this list of conditions and the following disclaimer.
+ * 2. Redistributions in binary form must reproduce the above copyright
+ * notice, this list of conditions and the following disclaimer in
+ * the documentation and/or other materials provided with the
+ * distribution.
+ * 3. Neither the name of The DragonFly Project nor the names of its
+ * contributors may be used to endorse or promote products derived
+ * from this software without specific, prior written permission.
+ *
+ * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
+ * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
+ * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS
+ * FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE
+ * COPYRIGHT HOLDERS OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT,
+ * INCIDENTAL, SPECIAL, EXEMPLARY OR CONSEQUENTIAL DAMAGES (INCLUDING,
+ * BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
+ * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED
+ * AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY,
+ * OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT
+ * OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
+ * SUCH DAMAGE.
+ *
+ * $DragonFly$
+ */
+
+#include <sys/stat.h>
+
+#include <dirent.h>
+#include <err.h>
+#include <errno.h>
+#include <fcntl.h>
+#include <inttypes.h>
+#include <unistd.h>
+
+#include "dma.h"
+
+/*
+ * Spool file format:
+ *
+ * 'Q'id files (queue):
+ * id envelope-to
+ *
+ * 'M'id files (data):
+ * envelope-from
+ * mail data
+ *
+ * Each queue file needs to have a corresponding data file.
+ * One data file might be shared by linking it several times.
+ *
+ * Queue ids are unique, formed from the inode of the spool file
+ * and a unique identifier.
+ */
+
+int
+newspoolf(struct queue *queue, const char *sender)
+{
+ char line[1000]; /* by RFC2822 */
+ char fn[PATH_MAX+1];
+ struct stritem *t;
+ struct qitem *it;
+ FILE *mailf;
+ off_t hdrlen;
+ int error;
+
+ if (snprintf(fn, sizeof(fn), "%s/%s", config->spooldir, "tmp_XXXXXXXXXX") <= 0)
+ return (-1);
+
+ queue->mailfd = mkstemp(fn);
+ if (queue->mailfd < 0)
+ return (-1);
+ if (flock(queue->mailfd, LOCK_EX) == -1)
+ return (-1);
+
+ queue->tmpf = strdup(fn);
+ if (queue->tmpf == NULL)
+ goto fail;
+
+ error = snprintf(line, sizeof(line), "%s\n", sender);
+ if (error < 0 || (size_t)error >= sizeof(line)) {
+ errno = E2BIG;
+ goto fail;
+ }
+ if (write(queue->mailfd, line, error) != error)
+ goto fail;
+
+ hdrlen = lseek(queue->mailfd, 0, SEEK_CUR);
+
+ mailf = fdopen(queue->mailfd, "r+");
+ if (mailf == NULL)
+ goto fail;
+ LIST_FOREACH(it, &queue->queue, next) {
+ it->mailf = mailf;
+ it->hdrlen = hdrlen;
+ }
+
+ t = malloc(sizeof(*t));
+ if (t != NULL) {
+ t->str = queue->tmpf;
+ SLIST_INSERT_HEAD(&tmpfs, t, next);
+ }
+ return (0);
+
+fail:
+ close(queue->mailfd);
+ unlink(fn);
+ return (-1);
+}
+
+int
+linkspool(struct queue *queue)
+{
+ char line[1000]; /* by RFC2822 */
+ struct stat st;
+ int error;
+ int queuefd;
+ struct qitem *it;
+
+ /*
+ * Assign queue id to each dest.
+ */
+ if (fstat(queue->mailfd, &st) != 0)
+ return (-1);
+ queue->id = st.st_ino;
+
+ /* XXX put this to a better place
+ syslog(LOG_INFO, "%"PRIxMAX": new mail from user=%s uid=%d envelope_from=<%s>",
+ queue->id, username, uid, sender);
+ */
+
+ LIST_FOREACH(it, &queue->queue, next) {
+ if (asprintf(&it->queueid, "%"PRIxMAX".%"PRIxPTR, queue->id, (uintptr_t)it) <= 0)
+ goto delfiles;
+ if (asprintf(&it->queuefn, "%s/Q%s", config->spooldir, it->queueid) <= 0)
+ goto delfiles;
+ if (asprintf(&it->mailfn, "%s/M%s", config->spooldir, it->queueid) <= 0)
+ goto delfiles;
+
+ /* Neither file may not exist yet */
+ if (stat(it->queuefn, &st) == 0 || stat(it->mailfn, &st) == 0)
+ goto delfiles;
+
+ error = snprintf(line, sizeof(line), "%s %s\n", it->queueid, it->addr);
+ if (error < 0 || (size_t)error >= sizeof(line))
+ goto delfiles;
+ queuefd = open_locked(it->queuefn, O_CREAT|O_EXCL|O_RDWR, 0600);
+ if (queuefd == -1)
+ goto delfiles;
+ if (write(queuefd, line, error) != error) {
+ close(queuefd);
+ goto delfiles;
+ }
+ it->queuefd = queuefd;
+
+ if (link(queue->tmpf, it->mailfn) != 0)
+ goto delfiles;
+ }
+
+ /* XXX
+ syslog(LOG_INFO, "%"PRIxMAX": mail to=<%s> queued as %s",
+ queue->id, it->addr, it->queueid);
+ */
+
+ unlink(queue->tmpf);
+ return (0);
+
+delfiles:
+ LIST_FOREACH(it, &queue->queue, next) {
+ unlink(it->queuefn);
+ unlink(it->mailfn);
+ }
+ return (-1);
+}
+
+void
+load_queue(struct queue *queue, int ignorelock)
+{
+ struct qitem *it;
+ //struct queue queue, itmqueue;
+ struct queue itmqueue;
+ DIR *spooldir;
+ struct dirent *de;
+ char line[1000];
+ FILE *queuef;
+ FILE *mailf;
+ char *sender;
+ char *addr;
+ char *queueid;
+ char *queuefn;
+ char *mailfn;
+ off_t hdrlen;
+ int fd;
+ int locked;
+
+ LIST_INIT(&queue->queue);
+
+ spooldir = opendir(config->spooldir);
+ if (spooldir == NULL)
+ err(1, "reading queue");
+
+ while ((de = readdir(spooldir)) != NULL) {
+ fd = -1;
+ sender = NULL;
+ queuef = NULL;
+ mailf = NULL;
+ queueid = NULL;
+ queuefn = NULL;
+ locked = 1;
+ LIST_INIT(&itmqueue.queue);
+
+ /* ignore temp files */
+ if (strncmp(de->d_name, "tmp_", 4) == 0 || de->d_type != DT_REG)
+ continue;
+ if (de->d_name[0] != 'Q')
+ continue;
+ if (asprintf(&queuefn, "%s/Q%s", config->spooldir, de->d_name + 1) < 0)
+ goto fail;
+ if (asprintf(&mailfn, "%s/M%s", config->spooldir, de->d_name + 1) < 0)
+ goto fail;
+
+ fd = open_locked(queuefn, O_RDONLY|O_NONBLOCK);
+ if (ignorelock && fd < 0) {
+ fd = open(queuefn, O_RDONLY);
+ locked = 0;
+ }
+ if (fd < 0) {
+ /* Ignore locked files */
+ if (errno == EWOULDBLOCK)
+ continue;
+ goto skip_item;
+ }
+
+ mailf = fopen(mailfn, "r");
+ if (mailf == NULL)
+ goto skip_item;
+ if (fgets(line, sizeof(line), mailf) == NULL || line[0] == 0)
+ goto skip_item;
+ line[strlen(line) - 1] = 0; /* chop newline */
+ sender = strdup(line);
+ if (sender == NULL)
+ goto skip_item;
+
+ hdrlen = ftell(mailf);
+
+ queuef = fdopen(fd, "r");
+ if (queuef == NULL)
+ goto skip_item;
+
+ if (fgets(line, sizeof(line), queuef) == NULL || line[0] == 0)
+ goto skip_item;
+ line[strlen(line) - 1] = 0;
+ queueid = strdup(line);
+ if (queueid == NULL)
+ goto skip_item;
+ addr = strchr(queueid, ' ');
+ if (addr == NULL)
+ goto skip_item;
+ *addr++ = 0;
+
+ if (add_recp(&itmqueue, addr, sender, 0) != 0)
+ goto skip_item;
+ it = LIST_FIRST(&itmqueue.queue);
+ it->queuefd = fd;
+ it->mailf = mailf;
+ it->queueid = queueid;
+ it->queuefn = queuefn;
+ it->mailfn = mailfn;
+ it->hdrlen = hdrlen;
+ it->locked = locked;
+ LIST_INSERT_HEAD(&queue->queue, it, next);
+
+ continue;
+
+skip_item:
+ warn("reading queue: `%s'", queuefn);
+ if (sender != NULL)
+ free(sender);
+ if (queuefn != NULL)
+ free(queuefn);
+ if (mailfn != NULL)
+ free(queuefn);
+ if (queueid != NULL)
+ free(queueid);
+ if (queuef != NULL)
+ fclose(queuef);
+ if (mailf != NULL)
+ fclose(mailf);
+ close(fd);
+ }
+ closedir(spooldir);
+ return;
+
+fail:
+ err(1, "reading queue");
+}
+
+void
+delqueue(struct qitem *it)
+{
+ unlink(it->queuefn);
+ close(it->queuefd);
+ unlink(it->mailfn);
+ fclose(it->mailf);
+ free(it);
+}
projects / people / ms / dma.git / commitdiff
