ezmlm-clean.c

Go to the documentation of this file.

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

 
int flagmime = MOD_MIME;        /* default is message as attachment */
int flagreturn = 1;               /* default return timed-out messages */
char flagcd = '\0';                   /* default: no transferencoding */
stralloc fnmsg = {0};
 
/* The defines are in "idx.h" */
 
static void die_read() { logmsg(WHO,111,FATAL,B(ERR_READ,fnmsg.s)); }
static void die_usage() { logmsg(WHO,100,USAGE,"ezmlm-clean [-mMrRvV] dir"); }
static void die_nomem() { logmsg(WHO,111,FATAL,ERR_NOMEM); }
 
datetime_sec when;
unsigned int older;
 
char textbuf[1024];
buffer bt;
struct qmail qq;
 
ssize_t qqwrite(int fd,char *buf, unsigned int len)
{
  qmail_put(&qq,buf,len);
  return len;
}
char outbuf[256];
buffer bq = BUFFER_INIT(qqwrite,-1,outbuf,sizeof(outbuf));
 
char *dir;
char strnum[FMT_ULONG];
datetime_sec hashdate;
char hboundary[HASHLEN];
 
stralloc outhost = {0};
stralloc outlocal = {0};
stralloc quoted = {0};
stralloc charset = {0};
 
stralloc mailinglist = {0};
stralloc listid = {0};
stralloc line = {0};
stralloc modtime = {0};
stralloc to = {0};
 
int flagconf;
int fd;
int match;
unsigned long msgnum = 0;
                        /* counter to make message-id unique, since we may */
                        /* send out several msgs. This is not bullet-proof.*/
                        /* Duplication occurs if we do x>1 msg && another  */
                        /* ezmlm started within x seconds, and with the    */
                        /* same pid. Very unlikely.                        */
 
/* gets outlocal, outhost, etc. This is done only if there are any timed-out*/
/* messages found, that merit a reply to the author. */
 
void readconfigs()
{
  getconf_line(&mailinglist,"mailinglist",1,dir);
  getconf_line(&listid,"listid",0,dir);
  getconf_line(&outhost,"outhost",1,dir);
  getconf_line(&outlocal,"outlocal",1,dir);
  set_cpouthost(&outlocal);
  set_cpoutlocal(&outlocal);
}
 
/* sends file pointed to by d to the address in the return-path of the message. */
 
void sendnotice(char *d)
{
  unsigned int x,y;
  const char *err;
 
  if (!flagconf) {
    readconfigs();
  }
  if (qmail_open(&qq, (stralloc *) 0) == -1)
    logmsg(WHO,111,FATAL,ERR_QMAIL_QUEUE);
 
  fd = open_read(d);
  if (fd == -1)
    logmsg(WHO,111,FATAL,B(ERR_OPEN,d));
  buffer_init(&bt,buffer_unixread,fd,textbuf,sizeof(textbuf));
 
  if (getln(&bt,&line,&match,'\n') == -1) die_read();
  if (!match) die_read();
  if (!case_startb(line.s,line.len,"return-path:")) die_read();
  x = 12 + byte_chr(line.s + 12,line.len-12,'<');
  y = byte_rchr(line.s + x,line.len-x,'>');
  if (x != line.len && x+y != line.len) {
    if (!stralloc_copyb(&to,line.s+x+1, y-1)) die_nomem();
    if (!stralloc_0(&to)) die_nomem();
  } else
    die_read();
 
  hdr_add2("Mailing-List: ",mailinglist.s,mailinglist.len);
  hdr_add2("List-ID: ",listid.s,listid.len);
  hdr_datemsgid(when+msgnum++);
  hdr_from("-help");
  hdr_listsubject1(TXT_RETURNED_POST);
  hdr_add2s("To: ",to.s);
  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);
    hdr_boundary(0);
    hdr_ctype(CTYPE_TEXT);
    hdr_transferenc();
  } else
    qmail_puts(&qq,"\n\n");
 
    ezcopy(&qq,"text/top",flagcd);
    ezcopy(&qq,"text/mod-timeout",flagcd);
    if (flagcd == 'B') {
      encode_b64("",0,&line,2);
      qmail_put(&qq,line.s,line.len);
    }
 
    if (flagmime) {
      hdr_boundary(0);
      hdr_ctype(CTYPE_MESSAGE);
      qmail_puts(&qq,"\n");
    }
 
    if (seek_begin(fd) == -1)
      logmsg(WHO,111,FATAL,B(ERR_SEEK,d));
 
    buffer_init(&bt,buffer_unixread,fd,textbuf,sizeof(textbuf));
    if (buffer_copy(&bq,&bt) != 0) die_read();
    close (fd);
 
    if (flagmime) hdr_boundary(1);
 
    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);                   /* sender */
    qmail_to(&qq,to.s);
 
    if (*(err = qmail_close(&qq)) != '\0')
      logmsg(WHO,111,FATAL,B(ERR_TMP_QMAIL_QUEUE,err + 1));
 
     strnum[fmt_ulong(strnum,qmail_qp(&qq))] = 0;
     logmsg(WHO,0,INFO,B("qp ",strnum,0));
}

 
void dodir(char *dirname,int reply) 
{
  DIR *moddir;
  direntry *d;
  unsigned long modtime;
  struct stat st;
 
  moddir = opendir(dirname);
  if (!moddir)
    logmsg(WHO,111,FATAL,B(ERR_OPEN,dir,"/",dirname));
 
  while ((d = readdir(moddir))) {
    if (d->d_name[0] == '.') continue;
    scan_ulong(d->d_name,&modtime);
    if (modtime < older) {
      if (!stralloc_copys(&fnmsg,dirname)) die_nomem();
      if (!stralloc_cats(&fnmsg,d->d_name)) die_nomem();
      if (!stralloc_0(&fnmsg)) die_nomem();
      if ((stat(fnmsg.s,&st) != -1) && (st.st_mode & 0200)) {
        if (reply && (st.st_mode & 0100)) {
          /* unlink unless there was a TEMPORARY */
          /* not message-related error notifying */
          /* poster and msg x bit set.  Leave r/o*/
          /* messages alone. Non-x bit msg are   */
          /* trash. Just unlink, don't notify    */
          sendnotice(fnmsg.s);
          unlink(fnmsg.s);
        } else
          unlink(fnmsg.s);
      }
    }
  }
  closedir(moddir);
}
int main(int argc,char **argv)
{
  int fdlock;
  unsigned long delay;
  int opt;
  umask(022);
  sig_pipeignore();
  when = now();
 
  while ((opt = getoptb(argc,argv,"mMrRvV")) != opteof)
    switch(opt) {
      case 'm': flagmime = 1; break;
      case 'M': flagmime = 0; break;
      case 'r': flagreturn = 1; break;
      case 'R': flagreturn = 0; break;
      case 'v':
      case 'V': logmsg(WHO,0,VERSION,auto_version); 
      default:  die_usage();
    }
 
  dir = argv[optind];
  if (!dir) die_usage();
 
  if (chdir(dir) == -1)
    logmsg(WHO,111,FATAL,B(ERR_SWITCH,dir));
 
  getconf_line(&modtime,"modtime",0,dir);
  if (!stralloc_0(&modtime)) die_nomem();
  scan_ulong(modtime.s,&delay);
  if (!delay) delay = DELAY_DEFAULT;
  else if (delay < DELAY_MIN) delay = DELAY_MIN;
  else if (delay > DELAY_MAX) delay = DELAY_MAX;
  older = (unsigned long) when - 3600L * delay;        /* delay is in hours */
 
  fdlock = lockfile("mod/lock");
 
  flagconf = 0;
  dodir("mod/pending/",flagreturn);
  dodir("mod/accepted/",0);
  dodir("mod/rejected/",0);
  dodir("mod/unconfirmed/",0);
  _exit(0);
 
  return 0;
}