Viewing file: 
outbox.c (4.24 KB) -rw-rw-rw-Select action/file-type:
(
+) |
(
+) |
(
+) |
Code (
+) |
Session (
+) |
(
+) |
SDB (
+) |
(
+) |
(
+) |
(
+) |
(
+) |
(
+) |
/*
** 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);
}
