1 files changed, 257 insertions, 0 deletions
diff --git a/imap/outbox.c b/imap/outbox.c
new file mode 100644
index 0000000..babafce
--- /dev/null
+++ b/imap/outbox.c
@@ -0,0 +1,257 @@
+/*
+** Copyright 2002-2009 Double Precision, Inc.
+** See COPYING for distribution information.
+*/
+
+#if	HAVE_CONFIG_H
+#include	"config.h"
+#endif
+#include	<stdio.h>
+#include	<stdlib.h>
+#include	<string.h>
+#include	<errno.h>
+#include	<signal.h>
+#include	<ctype.h>
+#include	<fcntl.h>
+#if	HAVE_UNISTD_H
+#include	<unistd.h>
+#endif
+
+#include	"outbox.h"
+#include	"imapwrite.h"
+
+#include	<sys/types.h>
+#include	<sys/stat.h>
+#if HAVE_SYS_WAIT_H
+#include	<sys/wait.h>
+#endif
+#ifndef WEXITSTATUS
+#define WEXITSTATUS(stat_val) ((unsigned)(stat_val) >> 8)
+#endif
+#ifndef WIFEXITED
+#define WIFEXITED(stat_val) (((stat_val) & 255) == 0)
+#endif
+
+/*
+** Is this the magic outbox?
+*/
+
+int is_outbox(const char *mailbox)
+{
+	const char *p=getenv("OUTBOX");
+
+	if (strncmp(mailbox, "./", 2) == 0)
+		mailbox += 2;
+
+	if (p == NULL || *p == 0 || strcmp(p, mailbox))
+		return (0);
+
+	return (1);
+}
+
+const char *defaultSendFrom()
+{
+	const char *from;
+
+	from=getenv("AUTHADDR");
+	if (!from || !*from)
+		from=getenv("AUTHENTICATED");
+	if (from && !*from)
+		from=NULL;
+
+	return from;
+}
+
+/*
+** After a message is copied to a folder, mail it, if it's an OUTBOX.
+*/
+
+static void errlogger(char *buffer)
+{
+	fprintf(stderr, "ERR: error sending a message, user=%s: %s\n",
+		getenv("AUTHENTICATED"), buffer);
+}
+
+int check_outbox(const char *message, const char *mailbox)
+{
+	char *argv[10];
+	const char *from;
+
+	if (!is_outbox(mailbox))
+		return (0);
+
+	from=defaultSendFrom();
+
+	argv[1]="-oi";
+	argv[2]="-t";
+	argv[3]=NULL;
+	if (from)
+	{
+		argv[3]="-f";
+		argv[4]=(char *)from;
+		argv[5]=NULL;
+	}
+
+	return (imapd_sendmsg(message, argv, errlogger));
+}
+
+int imapd_sendmsg(const char *message, char **argv, void (*err_func)(char *))
+{
+	char buffer[512];
+	int i;
+	int ch;
+	const char *from=defaultSendFrom();
+	const char *hdrfrom;
+
+	const char *prog;
+
+	int pipefd[2];
+	FILE *pipefp, *pipesendmail;
+	pid_t pid, pid2;
+	int waitstat;
+
+	signal(SIGCHLD, SIG_DFL);
+	signal(SIGPIPE, SIG_DFL);
+
+	if (pipe(pipefd) < 0)
+		write_error_exit("pipe");
+
+	prog=getenv("SENDMAIL");
+	if (!prog  || !*prog)
+		prog="sendmail";
+
+
+	pid=fork();
+
+	if (pid < 0)
+		write_error_exit("fork");
+
+	if (pid > 0)	/* Parent reads err message, checks exit status */
+	{
+		i=0;
+		close(pipefd[1]);
+		pipefp=fdopen(pipefd[0], "r");
+		if (pipefp == NULL)
+			write_error_exit("fdopen");
+		while ((ch=getc(pipefp)) != EOF)
+		{
+			if ((unsigned char)ch < ' ')
+				ch='/';
+			if (i < sizeof(buffer)-1)
+				buffer[i++]=ch;
+		}
+		fclose(pipefp);
+		close(pipefd[0]);
+		buffer[i]=0;
+
+		while ((pid2=wait(&waitstat)) != pid)
+			if (pid2 < 0 && errno == ECHILD)
+				break;
+
+		if (pid2 < 0 || !WIFEXITED(waitstat) || WEXITSTATUS(waitstat))
+		{
+			if (buffer[0] == '\0')
+			{
+				buffer[0]=0;
+				strncat(buffer, prog, 128);
+
+#ifdef WIFSIGNALED
+#ifdef WTERMSIG
+				if (WIFSIGNALED(waitstat))
+					sprintf(buffer+strlen(buffer),
+						" terminated with signal %d",
+						(int)WTERMSIG(waitstat));
+				else
+#endif
+#endif
+					strcat(buffer, " failed without logging an error.  This shouldn't happen.");
+			}
+
+			(*err_func)(buffer);
+			return (-1);
+		}
+		return (0);
+	}
+
+	close(pipefd[0]);
+	close(1);
+	close(2);
+	if (dup(pipefd[1]) != 1 || dup(pipefd[1]) != 2)
+	{
+		perror("dup(pipefd) failed");
+		exit(1);
+	}
+	close(pipefd[1]);
+
+	pipefp=fopen(message, "r");
+	if (pipefp == NULL)
+	{
+		perror(message);
+		exit(1);
+	}
+
+	/* Child forks again, second child process runs sendmail */
+
+	if (pipe(pipefd) < 0)
+	{
+		perror("pipe");
+		exit(1);
+	}
+
+	pid=fork();
+
+	if (pid < 0)
+	{
+		perror("fork");
+		exit(1);
+	}
+
+	if (pid == 0)
+	{
+		fclose(pipefp);
+		close(pipefd[1]);
+		close(0);
+		errno=EINVAL;
+		if (dup(pipefd[0]) != 0)
+		{
+			perror("dup");
+			exit(1);
+		}
+
+		argv[0]=(char *)prog;
+
+		execvp(prog, argv);
+		perror(prog);
+		exit(1);
+	}
+
+	close(pipefd[0]);
+
+	pipesendmail=fdopen(pipefd[1], "w");
+	if (!pipesendmail)
+	{
+		perror("fdopen");
+		kill(pid, SIGTERM);
+		close(pipefd[1]);
+		exit(1);
+	}
+
+	if ((hdrfrom=getenv("HEADERFROM")) != NULL && *hdrfrom && from)
+		fprintf(pipesendmail, "%s: %s\n", hdrfrom, from);
+	while ((ch=getc(pipefp)) != EOF)
+		putc(ch, pipesendmail);
+	fclose(pipefp);
+	fclose(pipesendmail);
+
+	while ((pid2=wait(&waitstat)) != pid)
+		if (pid2 < 0 && errno == ECHILD)
+			break;
+
+	if (pid2 < 0 || !WIFEXITED(waitstat) || WEXITSTATUS(waitstat))
+	{
+		fprintf(stderr, "Message send FAILED.\n");
+		exit(1);
+	}
+	exit(0);
+	return (0);
+}