ezmlm-confirm.c

Go to the documentation of this file.

#include <sys/types.h>
#include <sys/stat.h>
#include <unistd.h>
#include "error.h"
#include "case.h"
#include "stralloc.h"
#include "str.h"
#include "env.h"
#include "error.h"
#include "sig.h"
#include "wait.h"
#include "readclose.h"
#include "getconf.h"
#include "byte.h"
#include "getln.h"
#include "qmail.h"
#include "buffer.h"
#include "readwrite.h"
#include "seek.h"
#include "quote.h"
#include "datetime.h"
#include "now.h"
#include "fmt.h"
#include "getoptb.h"
#include "auto_bin.h"
#include "cookie.h"
#include "errtxt.h"
#include "ezcopy.h"
#include "open.h"
#include "lock.h"
#include "wrap.h"
#include "idx.h"
#include "mime.h"
#include "auto_version.h"
#include "logmsg.h"
#include "lockfile.h"
#include "ezmlm.h"
 
#define WHO "ezmlm-confirm"

 
static int flagmime = MOD_MIME; /* default is message as attachment */
 
static void die_usage() { logmsg(WHO,100,USAGE,B("ezmlm-confirm [-cCmMrRvV] dir [/path/ezmlm-send]")); }
static void die_nomem() { logmsg(WHO,111,FATAL,ERR_NOMEM); }
void die_badformat() { logmsg(WHO,100,FATAL,ERR_BAD_REQUEST); }
 
static stralloc key = {0};
static stralloc mailinglist = {0};
static stralloc to = {0};
static stralloc sendopt = {0};
static datetime_sec when;
 
static char hash[COOKIE];
static stralloc line = {0};
static stralloc fnbase = {0};
static stralloc fnmsg = {0};
 
static const char *dir;
static struct stat st;
 
struct qmail qq;
stralloc outhost = {0};
stralloc outlocal = {0};

 
static int checkfile(const char *fn)
{
  if (!stralloc_copys(&fnmsg,"mod/unconfirmed/")) die_nomem();
  if (!stralloc_cats(&fnmsg,fn)) die_nomem();
  if (!stralloc_0(&fnmsg)) die_nomem();
  if (stat(fnmsg.s,&st) == 0) return 1;
  if (errno != ENOENT)
    logmsg(WHO,111,FATAL,B(ERR_STAT,dir,"/",fnmsg.s));
 
  return 0;
}
 
static ssize_t qqwrite(int fd,char *buf,unsigned int len)
{
  qmail_put(&qq,buf,len);
  return len;
}
static char qqbuf[256];
buffer bq = BUFFER_INIT(qqwrite,-1,qqbuf,sizeof(qqbuf));
 
static buffer bt;
static char textbuf[1024];

 
static void maketo(void)
{
  unsigned int x, y;
 
  if (case_startb(line.s,line.len,"return-path:")) {
    x = 12 + byte_chr(line.s + 12,line.len - 12,'<');
    if (x != line.len) {
      y = byte_rchr(line.s + x,line.len - x,'>');
      if (y + x != line.len) {
        if (!stralloc_copyb(&to,line.s + x + 1,y - 1)) die_nomem();
        if (!stralloc_0(&to)) die_nomem();
      }                 /* no return path-> no addressee. A NUL in the sender */
    }                   /* is no worse than a faked sender, so no problem */
  }
}
 
int main(int argc, char **argv)
{
  const char *sender;
  const char *def;
  const char *local;
  const char *action;
  int fd;
  int match;
  char szchar[2] = "-";
  const char *replyto = (char *) 0;
  unsigned int start,confnum;
  int child;
  int opt;
  const char *cp;
 
  (void) umask(022);
  sig_pipeignore();
  when = now();
 
  if (!stralloc_copys(&sendopt,"-")) die_nomem();
  while ((opt = getopt(argc,argv,"cCmMrRt:T:vV")) != opteof)
    switch(opt) {    /* pass on ezmlm-send options */
      case 'c':                 /* ezmlm-send flags */
      case 'C':
      case 'r':
      case 'R': szchar[0] = (char) opt & 0xff;
        if (!stralloc_append(&sendopt,szchar)) die_nomem();
        break;
      case 'm': flagmime = 1; break;
      case 'M': flagmime = 0; break;
      case 't':
      case 'T': if (optarg) replyto = optarg; break;
      case 'v':
      case 'V': logmsg(WHO,0,VERSION,auto_version); 
      default:  die_usage();
    }
 
  dir = argv[optind++];
  if (!dir) die_usage();
 
  sender = env_get("SENDER");
  if (!sender) logmsg(WHO,100,FATAL,ERR_NOSENDER);
  local = env_get("LOCAL");
  if (!local) logmsg(WHO,100,FATAL,ERR_NOLOCAL);
  def = env_get("DEFAULT");
  if (!def) logmsg(WHO,100,FATAL,ERR_NODEFAULT);
 
  if (!*sender)
    logmsg(WHO,100,FATAL,ERR_BOUNCE);
  if (!sender[str_chr(sender,'@')])
    logmsg(WHO,100,FATAL,ERR_ANONYMOUS);
  if (str_equal(sender,"#@[]"))
    logmsg(WHO,100,FATAL,ERR_BOUNCE);
 
  if (chdir(dir) == -1)
    logmsg(WHO,111,FATAL,B(ERR_SWITCH,dir));
 
  switch (openreadclose("key",&key,32)) {
    case -1: logmsg(WHO,111,FATAL,B(ERR_READ,dir,"/key"));
    case 0:
      logmsg(WHO,100,FATAL,B(dir,"/key",ERR_NOEXIST));
  }
  getconf_line(&mailinglist,"mailinglist",1,dir);
  getconf_line(&outhost,"outhost",1,dir);
  getconf_line(&outlocal,"outlocal",1,dir);
  set_cpoutlocal(&outlocal);                /* for ezcopy() */
  set_cpouthost(&outhost);             /* for ezcopy() */
 
  /* local should be >= def, but who knows ... */
  cp = local + str_len(local) - str_len(def) - 2;
  if (cp < local) die_badformat();
  action = local + byte_rchr(local,cp - local,'-');
  if (action == cp) die_badformat();
  action++;
 
  if (!action[0]) die_badformat();
  if (!str_start(action,ACTION_CONFIRM) && !str_start(action,ACTION_DISCARD))
    die_badformat();
  start = str_chr(action,'-');
  if (!action[start]) die_badformat();
  confnum = 1 + start + str_chr(action + start + 1,'.');
  if (!action[confnum]) die_badformat();
  confnum += 1 + str_chr(action + confnum + 1,'.');
  if (!action[confnum]) die_badformat();
  if (!stralloc_copyb(&fnbase,action+start+1,confnum-start-1)) die_nomem();
  if (!stralloc_0(&fnbase)) die_nomem();
  cookie(hash,key.s,key.len,fnbase.s,"","a");
  if (byte_diff(hash,COOKIE,action+confnum+1))
    die_badformat();
 
  lockfile("mod/confirmlock");
 
  if (!checkfile(fnbase.s)) logmsg(WHO,100,FATAL,ERR_MOD_TIMEOUT);
 
/* Here, we have an existing filename in fnbase with the complete path */
/* from the current dir in fnmsg. */
 
  if (str_start(action,ACTION_DISCARD)) {
    unlink(fnmsg.s);
    logmsg(WHO,0,INFO,"info: post rejected");
  } else if (str_start(action,ACTION_CONFIRM)) {
    fd = open_read(fnmsg.s);
    if (fd == -1) {
      if (errno !=ENOENT)
        logmsg(WHO,111,FATAL,B(ERR_OPEN,fnmsg.s));
      else      /* shouldn't happen since we've got lock */
        logmsg(WHO,100,FATAL,B(fnmsg.s,ERR_MOD_TIMEOUT));
    }
 
    buffer_init(&bt,buffer_unixread,fd,textbuf,sizeof(textbuf));
                                /* read "Return-Path:" line */
    if (getln(&bt,&line,&match,'\n') == -1 || !match)
      logmsg(WHO,111,FATAL,ERR_READ_INPUT);
    maketo();                     /* extract SENDER to "to" */
    env_put2("SENDER",to.s);  /* set SENDER */
    if (seek_begin(fd) == -1) /* rewind, since we read an entire buffer */
      logmsg(WHO,111,FATAL,B(ERR_SEEK,fnmsg.s));
 
    if ((child = wrap_fork()) == 0) {
      close(0);
      dup(fd);        /* make fnmsg.s stdin */
      if (argc > optind)
        wrap_execsh(argv[optind]);
      else
        wrap_execbin("/ezmlm-send", &sendopt, dir);
    }
    /* parent */
    close(fd);
    wrap_exitcode(child);
 
    unlink(fnmsg.s);
    _exit(0);
  }
 
  return 0;
}