ezmlm-store.c

Go to the documentation of this file.

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

 
int flagmime = MOD_MIME;     /* default is message as attachment */
int flagpublic = 1;          /* default anyone can post */
                             /* =0 for only moderators can */
int flagself = 0;            /* `modpost` mods approve own posts */
                             /* but mod/ is used for moderators */
                             /* of other posts. Def=no=0 */
int flagconfirm = -1;        /* if true, sender must approve its own posts */
char flagcd = '\0';          /* default: don't use quoted-printable */
int flagbody = 1;            /* body of message enclosed with mod request */
                             /* 0 => headers only */
 
static void die_usage() { logmsg(WHO,100,USAGE,"ezmlm-store [-cCmMpPrRsSvV] dir"); }
static void die_nomem() { logmsg(WHO,111,FATAL,ERR_NOMEM); }
 
stralloc fnmsg = {0};
static void die_msg() { logmsg(WHO,111,FATAL,B(ERR_WRITE,fnmsg.s)); }
 
int fdmsg;
int fdmod;
int pid;
int match;
 
static char strnum[FMT_ULONG];
char hash[COOKIE];
char hboundary[COOKIE];
datetime_sec when;
struct stat st;
 
stralloc outhost = {0};
stralloc outlocal = {0};
 
stralloc fnbase = {0};
stralloc line = {0};
stralloc mailinglist = {0};
stralloc mydtline = {0};
stralloc returnpath = {0};
stralloc accept = {0};
stralloc action = {0};
stralloc reject = {0};
stralloc quoted = {0};
stralloc key = {0};
stralloc subject = {0};
stralloc moderators = {0};
stralloc confirmpost = {0};
stralloc charset = {0};
stralloc sendopt = {0};
 
struct qmail qq;
ssize_t qqwrite(int fd,char *buf,unsigned int len)
{
  qmail_put(&qq,buf,len);
  return len;
}
 
int subto(char *s,unsigned int l)
{
  qmail_put(&qq,"T",1);
  qmail_put(&qq,s,l);
  qmail_put(&qq,"",1);
  return (int) l;
}
 
char qqbuf[1];
buffer bq = BUFFER_INIT(qqwrite,-1,qqbuf,sizeof(qqbuf));
buffer bi;
char inbuf[1024];
buffer bo;
char outbuf[1024];
buffer bt;
char textbuf[512];
buffer bs;
char subbuf[512];

 
void makeacthash(stralloc *act)
{
  int d;
 
  d = 2 + str_chr(act->s + 1,'-');
  cookie(hash,key.s,key.len,act->s + d,"","a");
  *(act->s + act->len - 1) = '.';    /* we put a '.' Bad, but works */
  if (!stralloc_catb(act,hash,COOKIE)) die_nomem();
  if (!stralloc_cats(act,"@")) die_nomem();
  if (!stralloc_cat(act,&outhost)) die_nomem();
}
 
int main(int argc,char **argv)
{
  char *dir;
  int fdlock;
  char *sender;
  int match;
  int flaginheader;
  int flagmodpost;
  int flagremote;
  const char *pmod;
  const char *err;
  int opt;
  unsigned int i;
  char szchar[2] = "-";
  int child;
 
  umask(022);
  sig_pipeignore();
 
  if (!stralloc_copys(&sendopt,"-")) die_nomem();
 
  while ((opt = getoptb(argc,argv,"bBcCmMpPrRsSvVyY")) != opteof)
    switch(opt) {
      case 'b': flagbody = 1; break;
      case 'B': flagbody = 0; break;
      case 'm': flagmime = 1; break;
      case 'M': flagmime = 0; break;
      case 'p': flagpublic = 1; break;    /* anyone can post (still moderated)*/
      case 'P': flagpublic = 0; break;    /* only moderators can post */
      case 's': flagself = 1; break;    /* modpost and DIR/mod diff fxns */
      case 'S': flagself = 0; break;    /* same fxn */
      case 'y': flagconfirm = 1; break; /* force post confirmation */
      case 'Y': flagconfirm = 0; break; /* disable post confirmation */
      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 'v':
      case 'V': logmsg(WHO,0,VERSION,auto_version);
      default:  die_usage();
    }
 
  sender = env_get("SENDER");
 
  if (sender) {
    if (!*sender || str_equal(sender,"#@[]"))
      logmsg(WHO,100,FATAL,ERR_BOUNCE);
  }
 
  dir = argv[optind];
  if (!dir) die_usage();
 
  if (chdir(dir) == -1)
    logmsg(WHO,111,FATAL,B(ERR_SWITCH,dir));
 
  if (flagconfirm == -1)
    flagconfirm = getconf_line(&confirmpost,"confirmpost",0,dir);
  else
    getconf_line(&confirmpost,"confirmpost",0,dir);
 
  flagmodpost = getconf_line(&moderators,"modpost",0,dir);
  flagremote = getconf_line(&line,"remote",0,dir);
  if (!flagmodpost && !flagconfirm) {            /* not msg-mod. Pipe to ezmlm-send */
    if ((child = wrap_fork()) == 0)
      wrap_execbin("/ezmlm-send", &sendopt, dir);
                                                 /* parent */
    wrap_exitcode(child);
  }
 
  if (!moderators.len || !(moderators.s[0] == '/')) {
    if (!stralloc_copys(&moderators,dir)) die_nomem();
    if (!stralloc_cats(&moderators,"/mod")) die_nomem();
  }
  if (!stralloc_0(&moderators)) die_nomem();
 
  if (sender) {
      pmod = issub(moderators.s,sender,(char *) 0);
      closesql();
                                                 /* sender = moderator? */
  } else
    pmod = 0;
 
  if (!pmod && !flagpublic)
    logmsg(WHO,100,FATAL,ERR_NO_POST);
 
  switch (openreadclose("key",&key,32)) {
    case -1: logmsg(WHO,111,FATAL,B(ERR_READ,"/key: ",dir));
    case  0: logmsg(WHO,100,FATAL,B("/key",dir,ERR_NOEXIST));
  }
 
  getconf_line(&outhost,"outhost",1,dir);
  getconf_line(&outlocal,"outlocal",1,dir);
  getconf_line(&mailinglist,"mailinglist",1,dir);
 
  fdlock = lockfile("mod/lock");
 
  if (!stralloc_copys(&mydtline, flagconfirm
    ? "Delivered-To: confirm to "
    : "Delivered-To: moderator for ")) die_nomem();
  if (!stralloc_catb(&mydtline,outlocal.s,outlocal.len)) die_nomem();
  if (!stralloc_append(&mydtline,"@")) die_nomem();
  if (!stralloc_catb(&mydtline,outhost.s,outhost.len)) die_nomem();
  if (!stralloc_cats(&mydtline,"\n")) die_nomem();
 
  if (!stralloc_copys(&returnpath,"Return-Path: <")) die_nomem();
  if (sender) {
    if (!stralloc_cats(&returnpath,sender)) die_nomem();
    for (i = 14; i < returnpath.len;++i)
      if (returnpath.s[i] == '\n' || !returnpath.s[i] )
        returnpath.s[i] = '_';
        /* NUL and '\n' are bad, but we don't quote since this is */
        /* only for ezmlm-moderate, NOT for SMTP */
  }
  if (!stralloc_cats(&returnpath,">\n")) die_nomem();
 
  pid = getpid();                                /* unique file name */
 
  for (i = 0 ;; ++i) {                           /* got lock - nobody else can add files */
    when = now();                                /* when is also used later for date! */
    if (!stralloc_copys(&fnmsg, flagconfirm?"mod/unconfirmed/":"mod/pending/")) die_nomem();
    if (!stralloc_copyb(&fnbase,strnum,fmt_ulong(strnum,when))) die_nomem();
    if (!stralloc_append(&fnbase,".")) die_nomem();
    if (!stralloc_catb(&fnbase,strnum,fmt_ulong(strnum,pid))) die_nomem();
    if (!stralloc_cat(&fnmsg,&fnbase)) die_nomem();
    if (!stralloc_0(&fnmsg)) die_nomem();
    if (stat(fnmsg.s,&st) == -1) if (errno == ENOENT) break;
                                                 /* really should never get to this point */
   if (i == 2) logmsg(WHO,111,FATAL,ERR_UNIQUE);
   sleep(2);
  }
 
  if (!stralloc_copys(&action,"-")) die_nomem();
  if (!stralloc_cats(&action,flagconfirm?ACTION_DISCARD:ACTION_REJECT)) die_nomem();
  if (!stralloc_cat(&action,&fnbase)) die_nomem();
  if (!stralloc_0(&action)) die_nomem();
  makeacthash(&action);
  if (!quote(&quoted,&outlocal)) die_nomem();
  if (!stralloc_copy(&reject,&quoted)) die_nomem();
  if (!stralloc_cat(&reject,&action)) die_nomem();
  if (!stralloc_0(&reject)) die_nomem();
 
  if (!stralloc_copys(&action,"-")) die_nomem();
  if (!stralloc_cats(&action,flagconfirm?ACTION_CONFIRM:ACTION_ACCEPT)) die_nomem();
  if (!stralloc_cat(&action,&fnbase)) die_nomem();
  if (!stralloc_0(&action)) die_nomem();
  makeacthash(&action);
  if (!stralloc_copy(&accept,&quoted)) die_nomem();
  if (!stralloc_cat(&accept,&action)) die_nomem();
  if (!stralloc_0(&accept)) die_nomem();
 
  set_cpoutlocal(&outlocal);
  set_cpouthost(&outhost);
  set_cptarget(accept.s);    /* for copy () */
  set_cpconfirm(reject.s);
 
  fdmsg = open_trunc(fnmsg.s);
  if (fdmsg == -1)
    logmsg(WHO,111,FATAL,B(ERR_WRITE,dir,"/",fnmsg.s));
  buffer_init(&bo,buffer_unixwrite,fdmsg,outbuf,sizeof(outbuf));
 
  if (qmail_open(&qq, (stralloc *) 0) == -1)     /* Open mailer */
    logmsg(WHO,111,FATAL,ERR_QMAIL_QUEUE);
 
  hdr_add2("Mailing-List: ",mailinglist.s,mailinglist.len);
 
  if (getconf_line(&line,"listid",0,dir))
    hdr_add2("List-ID: ",line.s,line.len);
  hdr_datemsgid(when);
  if (flagconfirm)
    hdr_from("-owner");
  else
    hdr_add2s("From: ",reject.s);
 
  hdr_add2s("Reply-To: ",accept.s);
 
  if (!flagconfirm && !pmod && flagremote) {    /* if remote admin add -allow- address */
    qmail_puts(&qq,"Cc: ");    /* for ezmlm-gate users */
    strnum[fmt_ulong(strnum,(unsigned long) when)] = 0;
    cookie(hash,key.s,key.len-FLD_ALLOW,strnum,sender,"t");
    if (!stralloc_copy(&line,&outlocal)) die_nomem();
    if (!stralloc_cats(&line,"-allow-tc.")) die_nomem();
    if (!stralloc_cats(&line,strnum)) die_nomem();
    if (!stralloc_append(&line,".")) die_nomem();
    if (!stralloc_catb(&line,hash,COOKIE)) die_nomem();
    if (!stralloc_append(&line,"-")) die_nomem();
    i = str_rchr(sender,'@');
    if (!stralloc_catb(&line,sender,i)) die_nomem();
    if (sender[i]) {
      if (!stralloc_append(&line,"=")) die_nomem();
      if (!stralloc_cats(&line,sender + i + 1)) die_nomem();
    }
    qmail_put(&qq,line.s,line.len);
    qmail_puts(&qq,"@");
    qmail_put(&qq,outhost.s,outhost.len);
    qmail_puts(&qq,"\n");
  }
  if (flagconfirm) {
    qmail_puts(&qq,"To: <");
    if (sender)
      qmail_puts(&qq, sender);
    qmail_puts(&qq,">\n");
  } else {
    qmail_puts(&qq,"To: Recipient list not shown: ;\n");
  }
 
  /* FIXME: Drop the custom subject hack and use hdr_listsubject1 */
 
  if (!stralloc_copys(&subject,"Subject: ")) die_nomem();
  if (flagconfirm) {
    if (confirmpost.len) {
      if (!stralloc_cat(&subject,&confirmpost)) die_nomem();
      if (!stralloc_cats(&subject," ")) die_nomem();
    } else {
      if (!stralloc_cats(&subject,TXT_CONFIRM_POST)) die_nomem();
    }
  } else {
    if (!stralloc_cats(&subject,TXT_MODERATE)) die_nomem();
  }
  if (!quote(&quoted,&outlocal)) die_nomem();
  if (!stralloc_cat(&subject,&quoted)) die_nomem();
  if (!stralloc_append(&subject,"@")) die_nomem();
  if (!stralloc_cat(&subject,&outhost)) die_nomem();
  if (flagmime) {
    if (getconf_line(&charset,"charset",0,dir)) {
      if (charset.len >= 2 && charset.s[charset.len - 2] == ':') {
        if (charset.s[charset.len - 1] == 'B' ||
            charset.s[charset.len - 1] == 'Q') {
          flagcd = charset.s[charset.len - 1];
          charset.s[charset.len - 2] = '\0';
        }
      }
    } else
      if (!stralloc_copys(&charset,TXT_DEF_CHARSET)) die_nomem();
    if (!stralloc_0(&charset)) die_nomem();
    hdr_mime(CTYPE_MULTIPART);
    qmail_put(&qq,subject.s,subject.len);
    hdr_boundary(0);
    hdr_ctype(CTYPE_TEXT);
    hdr_transferenc();
  } else {
    qmail_put(&qq,subject.s,subject.len);
    qmail_puts(&qq,"\n\n");
  }
  ezcopy(&qq,flagconfirm?"text/post-confirm":"text/mod-request",flagcd);
  if (flagcd == 'B') {
    encode_b64("",0,&line,2);
    qmail_put(&qq,line.s,line.len);
  }
  if (buffer_put(&bo,returnpath.s,returnpath.len) == -1) die_msg();
  if (buffer_put(&bo,mydtline.s,mydtline.len) == -1) die_msg();
  buffer_init(&bi,buffer_unixread,0,inbuf,sizeof(inbuf));
 
  if (flagmime) {
    hdr_boundary(0);
    hdr_ctype(CTYPE_MESSAGE);
    qmail_puts(&qq, "\n");
  }
 
  qmail_put(&qq,returnpath.s,returnpath.len);
  qmail_put(&qq,mydtline.s,mydtline.len);
  flaginheader = 1;
 
  for (;;) {
    if (getln(&bi,&line,&match,'\n') == -1)
      logmsg(WHO,111,FATAL,ERR_READ_INPUT);
    if (!match) break;
    if (line.len == 1) flaginheader = 0;
    if (flaginheader) {
      if ((line.len == mydtline.len) && !byte_diff(line.s,line.len,mydtline.s)) {
        close(fdmsg);                            /* be nice - clean up */
        unlink(fnmsg.s);
        logmsg(WHO,100,FATAL,ERR_LOOPING);
      }
      if (case_startb(line.s,line.len,"mailing-list:")) {
        close(fdmsg);                            /* be nice - clean up */
        unlink(fnmsg.s);
        logmsg(WHO,100,FATAL,ERR_MAILING_LIST);
      }
    }
 
    if (flagbody || flaginheader)                /* skip body if !flagbody */
      qmail_put(&qq,line.s,line.len);
    if (buffer_put(&bo,line.s,line.len) == -1) die_msg();
  }
 
  if (flagmime)
    hdr_boundary(1);
 
/* close archive before qmail. Loss of qmail will result in re-run, and   */
/* worst case this results in a duplicate msg sitting orphaned until it's */
/* cleaned out.                                                           */
 
  if (buffer_flush(&bo) == -1) die_msg();
  if (fsync(fdmsg) == -1) die_msg();
  if (fchmod(fdmsg,MODE_MOD_MSG | 0700) == -1) die_msg();
  if (close(fdmsg) == -1) die_msg();             /* NFS stupidity */
 
  close(fdlock);
 
  if (flagconfirm) {
    qmail_from(&qq,reject.s);                    /* envelope sender */
  } else {
    if (!stralloc_copy(&line,&outlocal)) die_nomem();
    if (!stralloc_cats(&line,"-return-@")) die_nomem();
    if (!stralloc_cat(&line,&outhost)) die_nomem();
    if (!stralloc_0(&line)) die_nomem();
    qmail_from(&qq,line.s);                      /* envelope sender */
  }
  if (flagconfirm)                               /* to sender */
    qmail_to(&qq,sender);
  else if (pmod)                                 /* to moderator only */
    qmail_to(&qq,pmod);
  else {
    if (flagself) {                              /* to all moderators */
      if (!stralloc_copys(&moderators,dir)) die_nomem();
      if (!stralloc_cats(&moderators,"/mod")) die_nomem();
      if (!stralloc_0(&moderators)) die_nomem();
    }
    putsubs(moderators.s,0,52,subto,1);
  }
 
  if (*(err = qmail_close(&qq)) == '\0') {
      strnum[fmt_ulong(strnum,qmail_qp(&qq))] = 0;
      logmsg(WHO,0,INFO,B("qp ",strnum));
  } else
      logmsg(WHO,111,FATAL,B(ERR_TMP_QMAIL_QUEUE,err+1));
 
  return 0;
}