ezmlm-gate.c

Go to the documentation of this file.

#include <sys/types.h>
#include <sys/stat.h>
#include <unistd.h>
#include "buffer.h"
#include "stralloc.h"
#include "error.h"
#include "env.h"
#include "sig.h"
#include "str.h"
#include "seek.h"
#include "wait.h"
#include "exit.h"
#include "getconf.h"
#include "auto_bin.h"
#include "getoptb.h"
#include "errtxt.h"
#include "idx.h"
#include "subscribe.h"
#include "wrap.h"
#include "auto_version.h"
#include "logmsg.h"
 
#define WHO "ezmlm-gate"

 
 
static void die_usage() { logmsg(WHO,100,USAGE,"ezmlm-gate [-cCmMpPqrRsSvV] dir [moddir [...]]"); }
static void die_nomem() { logmsg(WHO,111,FATAL,ERR_NOMEM); }
 
stralloc line = {0};
stralloc cmds = {0};
stralloc sendopt = {0};
stralloc storeopt = {0};
 
char szchar[2] = "-";
  int child;
  const char *pmod;
 
int mailprog(char *s)
{
    int r;
 
    if ((child = wrap_fork()) == 0)
      wrap_execsh(s);
                                       /* parent */
                                       /* 100 perm error, 111 temp, 99 dom ok */
                                       /* 0 rec ok, others bounce */
    switch ((r = wrap_waitpid(child))) {
      case 0: case 99: case 100: break;
      case 111: logmsg(WHO,111,FATAL,ERR_CHILD_TEMP);
      default:  logmsg(WHO,100,FATAL,ERR_REJECT);    /* other errors => bounce */
    }
    if (seek_begin(0) == -1)           /* rewind */
      logmsg(WHO,111,FATAL,ERR_SEEK_INPUT);
    return r;
}
 
void main( int argc,char **argv)
{
  char *dir;
  char *sender;
  char *moddir;
  const char *queryext = (char *) 0;
  int opt;
  int ret = 0;
  int dontact = 0;
  unsigned int i,j;
  const char *program;
  stralloc *opts;
 
  umask(022);
  sig_pipeignore();
 
  /* storeopts to ezmlm-store only. */
  /* Others to both (ezmlm-store may pass them on to ezmlm-send. */
 
  if (!stralloc_copys(&sendopt,"-")) die_nomem();
  if (!stralloc_copys(&storeopt,"-")) die_nomem();
 
  while ((opt = getoptb(argc,argv,"0cCmMpPq:Q:sSrRt:T:vVyY")) != opteof)
    switch(opt) {                      /* pass on unrecognized options */
      case 'c':                        /* ezmlm-send flags */
      case 'C':
      case 'r':
      case 'Q':
      case 'R': szchar[0] = opt;
                if (!stralloc_append(&sendopt,szchar)) die_nomem();
                if (!stralloc_append(&storeopt,szchar)) die_nomem(); break;
      case 'm':                        /* ezmlm-store flags */
      case 'M':
      case 'p':
      case 'P':
      case 's':
      case 'S':
      case 'y':
      case 'Y': szchar[0] = opt;
                if (!stralloc_append(&storeopt,szchar)) die_nomem(); break;
      case 'q': if (optarg) queryext = optarg; break;
      case 'v':
      case 'V': logmsg(WHO,0,VERSION,auto_version);
      case '0': dontact = 1; break; break;
      default:  die_usage();           /* ezmlm-store flags */
    }
 
  dir = argv[optind++];
  if (!dir) die_usage();
  if (chdir(dir) == -1)
    logmsg(WHO,111,FATAL,B(ERR_SWITCH,dir));
 
  sender = env_get("SENDER");
 
  pmod = (char *)0;
 
  if (queryext) {
    getconf(&cmds,queryext,1,dir);
    i = 0;
    for (j = 0;j < cmds.len; ++j)
      if (!cmds.s[j]) {
    switch (cmds.s[i]) {
      case '\0': case '#': break;      /* ignore blank/comment */
      case '|':  ret = mailprog(cmds.s + i + 1); break;
      default:   ret = mailprog(cmds.s + i); break;
    }
    if (ret) break;
    i = j + 1;
    }
    if (!ret || ret == 99)             /* 111 => temp error */
      pmod = "";                       /* 0, 99 => post; other => moderate */
  }
  moddir = argv[optind++];
  if (moddir && !ret) {                /* if exit 0 and moddir, add issub */
    pmod = (char *)0;
    while (moddir && !pmod && sender) {
      pmod = issub(moddir,sender,(char *)0);
      closesql();
      moddir = argv[optind++];
    }
  }
 
  if (pmod) {
    program = "/ezmlm-send";
    opts = &sendopt;
  }
  else {
    program = "/ezmlm-store";
    opts = &storeopt;
  }
 
  if (dontact) {
    buffer_puts(buffer_2,auto_bin);
    buffer_puts(buffer_2,program);
    buffer_put(buffer_2," ", 1);
    buffer_put(buffer_2,opts->s, opts->len);
    buffer_put(buffer_2," ", 1);
    buffer_puts(buffer_2,dir);
    buffer_putsflush(buffer_2,"\n");
    return;
  }
 
  if ((child = wrap_fork()) == 0)
    wrap_execbin(program, opts, dir);
  /* parent */
  wrap_exitcode(child);
}