ezmlm-receipt.c

Go to the documentation of this file.

#include <sys/types.h>
#include "direntry.h"
#include "stralloc.h"
#include "str.h"
#include "env.h"
#include "readclose.h"
#include "getconf.h"
#include "strerr.h"
#include "byte.h"
#include "case.h"
#include "quote.h"
#include "getln.h"
#include "buffer.h"
#include "error.h"
#include "readwrite.h"
#include "fmt.h"
#include "now.h"
#include "seek.h"
#include "idx.h"
#include "errtxt.h"
#include "logmsg.h"
#include "ezmlm.h"
 
#define WHO "ezmlm-receipt"

 
static void die_usage() { logmsg(WHO,100,USAGE,"ezmlm-receipt [-dD] dir"); }
static void die_nomem() { logmsg(WHO,111,FATAL,ERR_NOMEM); }
static void die_badaddr() { logmsg(WHO,100,FATAL,ERR_BAD_ADDRESS); }
static void die_trash() { logmsg(WHO,0,INFO,"trash address"); }
 
outhost = {0};
outlocal = {0};
quoted = {0};
 
stralloc line = {0};
stralloc quoted = {0};
stralloc intro = {0};
stralloc bounce = {0};
stralloc header = {0};
stralloc failure = {0};
stralloc paragraph = {0};
stralloc ddir = {0};
stralloc inlocal = {0};
stralloc tagline = {0};
stralloc listaddr = {0};
stralloc fndate = {0};
stralloc fndir = {0};
stralloc fndatenew = {0};
 
void die_datenew() { logmsg(WHO,111,FATAL,B(ERR_WRITE,fndatenew.s)); } 
void die_msgin() { logmsg(WHO,111,FATAL,ERR_READ_INPUT); }
 
char strnum[FMT_ULONG];
char inbuf[1024];
buffer bi;
 
char outbuf[256];                         /* small - rarely used */
buffer bo;
 
unsigned long when;
unsigned long addrno = 0L;
 
char *sender;
char *dir;
char *workdir;
void **psql = (void **) 0;
stralloc listno = {0};

 
void doit(char *addr,unsigned long msgnum,unsigned long when,stralloc *bounce)
{
  int fd;
  unsigned int pos;
  DIR *bouncedir;
  direntry *d;
  unsigned int no;
 
  if (!stralloc_copys(&fndir,workdir)) die_nomem();
  if (!stralloc_cats(&fndir,"/bounce")) die_nomem();
  if (!stralloc_0(&fndir)) die_nomem();
  bouncedir = opendir(fndir.s);
  if (!bouncedir)
    if (errno != ENOENT)
      logmsg(WHO,111,FATAL,B(ERR_OPEN,line.s));
    else
      logmsg(WHO,111,FATAL,B(fndir.s,ERR_NOEXIST));
 
  no = MAX_MAIN_BOUNCES;               /* no more than this many allowed */
  while (no && (d = readdir(bouncedir))) {
    if (str_equal(d->d_name,".")) continue;
    if (str_equal(d->d_name,"..")) continue;
    --no;
  }
  closedir(bouncedir);
  if (!no)                             /* max no of bounces exceeded */
    logmsg(WHO,0,INFO,ERR_MAX_BOUNCE);
 
  if (!stralloc_copys(&fndate,workdir)) die_nomem();       /* save bounce */
  if (!stralloc_cats(&fndate,"/bounce/d")) die_nomem();
  pos = fndate.len - 1;
  if (!stralloc_catb(&fndate,strnum,fmt_ulong(strnum,when))) die_nomem();
  if (!stralloc_cats(&fndate,".")) die_nomem();
  if (!stralloc_catb(&fndate,strnum,fmt_ulong(strnum,(unsigned long) getpid())))
     die_nomem();
  if (addrno) {                        /* so that pre-VERP bounces make a d... file per address */
                                       /* for the first one we use the std-style fname */
    if (!stralloc_cats(&fndate,".")) die_nomem();
    if (!stralloc_catb(&fndate,strnum,fmt_ulong(strnum,addrno))) die_nomem();
  }
  addrno++;                            /* get ready for next */
  if (!stralloc_0(&fndate)) die_nomem();
  if (!stralloc_copy(&fndatenew,&fndate)) die_nomem();
  fndatenew.s[pos] = 'D';
 
  fd = open_trunc(fndatenew.s);
  if (fd == -1) die_datenew();
  buffer_fdbuf(&bo,write,fd,outbuf,sizeof(outbuf));
  if (buffer_puts(&bo,addr) == -1) die_datenew();
  if (buffer_put(&bo,"",1) == -1) die_datenew();
  if (buffer_put(&bo,strnum,fmt_ulong(strnum,msgnum)) == -1)
    die_datenew();
  if (buffer_put(&bo,"",1) == -1) die_datenew();
 
  if (buffer_puts(&bo,"Return-Path: <") == -1) die_datenew();
  if (!quote2(&quoted,sender)) die_nomem();
  if (buffer_put(&bo,quoted.s,quoted.len) == -1) die_datenew();
  if (buffer_puts(&bo,">\n") == -1) die_datenew();
  if (buffer_put(&bo,bounce->s,bounce->len) == -1) die_datenew();
  if (buffer_flush(&bo) == -1) die_datenew();
  if (fsync(fd) == -1) die_datenew();
  if (close(fd) == -1) die_datenew(); /* NFS stupidity */
  if (rename(fndatenew.s,fndate.s) == -1)
    logmsg(WHO,111,FATAL,B(ERR_MOVE,fndatenew.s," to ",fndate.s));
}
 
int main(int argc,char **argv)
{
  char *local;
  char *host;
  char *action;
  char *def;
  int flagdig = 1;
  int flaghaveintro;
  int flaghaveheader;
  int match;
  unsigned long msgnum;
  unsigned int i;
  unsigned int len;
  char *cp;
 
  umask(022);
  sig_pipeignore();
 
  when = (unsigned long) now();
 
  dir = argv[1];
  if (!dir) die_usage();
  if (*dir == '-') {
    if (dir[1] == 'd') {
      flagdig = 2;
    } else if (dir[1] == 'D') {
      flagdig = 0;
    } else
      die_usage();
    dir = argv[2];
    if (!dir) die_usage();
  }
  if (chdir(dir) == -1)
    logmsg(WHO,111,FATAL,B(ERR_SWITCH,dir));
 
  sender = env_get("SENDER");
  def = env_get("DEFAULT");
  local = env_get("LOCAL");
 
  getconf_line(&outhost,"outhost",1,FATAL,dir);
  getconf_line(&outlocal,"outlocal",1,FATAL,dir);
  workdir = dir;
  if (def) {                           /* qmail>=1.02 */
    action = def;                      /* now see if -digest-return- */
    if (flagdig == 1) {
      flagdig = 0;
      if (str_len(local) >= str_len(def) + 14)
    if (str_start(local + str_len(local) - 14 - str_len(def),"digest-"))
      flagdig = 2;
    }
  }
  if (flagdig) {
    if (!stralloc_copys(&ddir,dir)) die_nomem();
    if (!stralloc_cats(&ddir,"/digest")) die_nomem();
    if (!stralloc_0(&ddir)) die_nomem();
    workdir = ddir.s;
    if (!stralloc_cats(&outlocal,"-digest")) die_nomem();
  }
  if (!*action) die_trash();
 
  buffer_init(&bi,unixread,0,inbuf,sizeof(inbuf));
 
  if (!case_diffs(action,"receipt")) {
    host = sender + str_rchr(sender,'@');
    if (*host)
      *(host++) = '\0';
    cp = sender;
                                       /* check recipient in case it's a bounce*/
    while (*(cp++)) {                  /* decode sender */
      cp += str_chr(cp,'-');
      if (case_starts(cp,"-return-")) {
        if (!scan_ulong(cp + 8,&msgnum))
          logmsg(WHO,100,FATAL,"bad VERP format for receipt");
         *cp = '\0';
        if (!stralloc_copys(&listaddr,sender)) die_nomem();
        if (!stralloc_append(&listaddr,"@")) die_nomem();
        if (!stralloc_cats(&listaddr,host)) die_nomem();
        if (!stralloc_0(&listaddr)) die_nomem();
        break;
      }
    }
    for (;;) {                         /* Get X-tag from hdr*/
      if (getln(&bi,&line,&match,'\n') == -1) die_msgin();
      if (!match)
        break;
 
      if (line.len == 1) break;
      if (case_startb(line.s,line.len,TXT_TAG)) {
        len = str_len(TXT_TAG);
        if (!stralloc_catb(&tagline,line.s +len,line.len - len -1)) die_nomem();
        /* NOTE: tagline is dirty! We quote it for sql and rely on */
        /* std log clean for maillog */
        break;
      }
    }
 
    /* feedback ok even if not sub. Will be filtered by subreceipt*/
    /* For instance, main list feedback is ok, but !issub. */
 
    subreceipt(workdir,msgnum,&tagline,listaddr.s,2,INFO,FATAL);
    closesql();
    _exit(0);
  }
                  /* not receipt - maybe bounce */
                  /* no need to lock. dttt.pid can be assumed */
                  /* to be unique and if not would be over- */
                  /* written even with lock */
 
  action += scan_ulong(action,&msgnum);
  if (*action != '-') die_badaddr();
  ++action;
                                       /* scan bounce for tag. It'll be in the BODY! */
  for (;;) {
    if (getln(&bi,&line,&match,'\n') == -1)
      logmsg(WHO,111,FATAL,ERR_READ_INPUT);
    if (!match) break;
    if (case_startb(line.s,line.len,TXT_TAG)) {
      len = str_len(TXT_TAG);
      if (!stralloc_catb(&tagline,line.s +len,line.len - len -1)) die_nomem();
                   /* NOTE: tagline is dirty! We quote it for sql and rely on */
                   /* std log clean for maillog */
      break;
    }
  }
  if (seek_begin(0) == -1)
    logmsg(WHO,111,FATAL,ERR_SEEK_INPUT);
  buffer_init(&bi,unixread,0,inbuf,sizeof(inbuf));
 
  if (*action) {                       /* normal bounce */
    if (readclose(0,&bounce,1024) == -1) die_msgin();
    i = str_rchr(action,'=');
    if (!stralloc_copyb(&listaddr,action,i)) die_nomem();
    if (action[i]) {
      if (!stralloc_cats(&listaddr,"@")) die_nomem();
      if (!stralloc_cats(&listaddr,action + i + 1)) die_nomem();
    }
    if (!stralloc_0(&listaddr)) die_nomem();
                   /* don't check for sub, since issub() doesn't see sublists */
    switch (subreceipt(workdir,msgnum,&tagline,listaddr.s,-1,INFO,FATAL)) {
      case -1: logmsg(WHO,0,INFO,ERR_COOKIE);
      case -2: logmsg(WHO,0,INFO,ERR_NOT_ACTIVE);
      default: doit(listaddr.s,msgnum,when,&bounce);
    }
    closesql();
    _exit(0);
  }                                    /* pre-VERP bounce, in QSBMF format */
 
  flaghaveheader = 0;
  flaghaveintro = 0;
 
  for (;;) {
    if (!stralloc_copys(&paragraph,"")) die_nomem();
    for (;;) {
      if (getln(&bi,&line,&match,'\n') == -1)
        logmsg(WHO,111,FATAL,ERR_READ_INPUT);
      if (!match) die_trash();
      if (!stralloc_cat(&paragraph,&line)) die_nomem();
      if (line.len <= 1) break;
    }
 
    if (!flaghaveheader) {
      if (!stralloc_copy(&header,&paragraph)) die_nomem();
      flaghaveheader = 1;
      continue;
    }
 
    if (!flaghaveintro) {
      if (paragraph.s[0] == '-' && paragraph.s[1] == '-')
        continue;                      /* skip MIME boundary if it exists */
      if (paragraph.len < 15) die_trash();
      if (str_diffn(paragraph.s,"Hi. This is the",15)) die_trash();
      if (!stralloc_copy(&intro,&paragraph)) die_nomem();
      flaghaveintro = 1;
      continue;
    }
 
    if (paragraph.s[0] == '-')
      break;
 
    if (paragraph.s[0] == '<') {       /* find address */
      if (!stralloc_copy(&failure,&paragraph)) die_nomem();
      if (!stralloc_copy(&bounce,&header)) die_nomem();
      if (!stralloc_cat(&bounce,&intro)) die_nomem();
      if (!stralloc_cat(&bounce,&failure)) die_nomem();
 
      i = byte_chr(failure.s,failure.len,'\n');
      if (i < 3) die_trash();
 
      if (!stralloc_copyb(&listaddr,failure.s + 1,i - 3)) die_nomem();
      if (byte_chr(listaddr.s,listaddr.len,'\0') == listaddr.len) {
        if (!stralloc_0(&listaddr)) die_nomem();
        if (subreceipt(workdir,msgnum,&tagline,listaddr.s,-1,INFO,FATAL) == 0)
        doit(listaddr.s,msgnum,when,&bounce);
      }
    }
  }
  closesql();
  _exit(0);
 
  return 0;
}