/*$Id: ezmlm-gate.c,v 1.18 1999/10/09 16:49:56 lindberg Exp $*/
/*$Name: ezmlm-idx-040 $*/

#include "stralloc.h"
#include "strerr.h"
#include "error.h"
#include "env.h"
#include "sig.h"
#include "str.h"
#include "seek.h"
#include "fork.h"
#include "wait.h"
#include "exit.h"
#include "getconf.h"
#include "auto_bin.h"
#include "sgetopt.h"
#include "errtxt.h"
#include "idx.h"
#include "subscribe.h"

#define FATAL "ezmlm-gate: fatal: "

void die_usage()
{
  strerr_die1x(100,"ezmlm-gate: usage: ezmlm-gate [-cCmMpPqrRsSvV] "
			"dir [moddir [...]]");
}
void die_nomem() { strerr_die2x(111,FATAL,ERR_NOMEM); }

stralloc line = {0};
stralloc cmds = {0};
stralloc send = {0};
stralloc sendopt = {0};
stralloc storeopt = {0};
void *psql = (void *) 0;

char szchar[2] = "-";
  char *sendargs[4];
  int child;
  int wstat;
  char *pmod;

int mailprog(s)
  char *s;
{
    int r;

    sendargs[0] = "/bin/sh";	/* 100 perm error, 111 temp, 99 dom ok */
    sendargs[1] = "-c";		/* 0 rec ok, others bounce */
    sendargs[2] = s;
    sendargs[3] = (char *)0;
    switch(child = fork()) {
      case -1:
	strerr_die2sys(111,FATAL,ERR_FORK);
      case 0:
	execv(*sendargs,sendargs);
	if (errno == error_txtbsy || errno == error_nomem ||
	  errno == error_io)
	        strerr_die5sys(111,FATAL,ERR_EXECUTE,
		  "/bin/sh -c ",sendargs[2],": ");
        else
		strerr_die5sys(100,FATAL,ERR_EXECUTE,
		  "/bin/sh -c ",sendargs[2],": ");
    }
         /* parent */
    wait_pid(&wstat,child);
    if (wait_crashed(wstat))
	strerr_die2x(111,FATAL,ERR_CHILD_CRASHED);
    switch((r = wait_exitcode(wstat))) {
      case 0: case 99: case 100: break;
      case 111:					/* temp error */
        strerr_die2x(111,FATAL,ERR_CHILD_TEMP);
      default:
        strerr_die2x(100,FATAL,ERR_REJECT);	/* other errors => bounce */
    }
    if (seek_begin(0) == -1)			/* rewind */
      strerr_die2sys(111,FATAL,ERR_SEEK_INPUT);
    return r;
}

void main(argc,argv)
int argc;
char **argv;
{
  char *dir;
  char *sender;
  char *moddir;
  char *queryext = (char *) 0;
  int opt;
  int ret = 0;
  unsigned int i,j,k;

  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 = getopt(argc,argv,
      "cCmMpPq:Q:sSrRt:T:vV")) != opteof)
    switch(opt) {	/* pass on unrecognized options */
      case 'c':			/* ezmlm-send flags */
      case 'C':
      case 'r':
      case 'R':
        szchar[0] = opt;
        if (!stralloc_append(&sendopt,szchar)) die_nomem();
        break;
      case 'm':			/* ezmlm-store flags */
      case 'M':
      case 'p':
      case 'P':
      case 's':
      case 'S':
        szchar[0] = opt;
        if (!stralloc_append(&storeopt,szchar)) die_nomem();
        break;
      case 'q':			/* allow both qQ to be nice */
      case 'Q': if (optarg) queryext = optarg; break;
      case 'v':
      case 'V': strerr_die2x(0,"ezmlm-gate version: ",EZIDX_VERSION);
      default:			/* ezmlm-store flags */
        die_usage();
    }

  dir = argv[optind++];
  if (!dir) die_usage();
  if (chdir(dir) == -1)
    strerr_die4sys(111,FATAL,ERR_SWITCH,dir,": ");

  sender = env_get("SENDER");

  pmod = (char *) 0;

  if (queryext) {
    getconf(&cmds,queryext,1,FATAL,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,FATAL);
      closesql();
      moddir = argv[optind++];
    }
  }

  sendargs[0] = "sh";
  sendargs[1] = "-c";
  if (!stralloc_copys(&send,auto_bin)) die_nomem();
  if (pmod) {
    if (!stralloc_cats(&send,"/ezmlm-send")) die_nomem();
    if (sendopt.len > 2)
      if (!stralloc_cat(&send,&sendopt)) die_nomem();

  } else {
    if (!stralloc_cats(&send,"/ezmlm-store")) die_nomem();
    if (storeopt.len > 2)
      if (!stralloc_cat(&send,&storeopt)) die_nomem();
    if (sendopt.len > 2)
      if (!stralloc_cat(&send,&sendopt)) die_nomem();
  }
  if (!stralloc_cats(&send," '")) die_nomem();
  if (!stralloc_cats(&send,dir)) die_nomem();
  if (!stralloc_cats(&send,"'")) die_nomem();
  if (!stralloc_0(&send)) die_nomem();
  sendargs[2] = send.s;
  sendargs[3] = 0;

  switch(child = fork()) {
    case -1:
      strerr_die2sys(111,FATAL,ERR_FORK);
    case 0:
      execvp(*sendargs,sendargs);
      if (errno == error_txtbsy || errno == error_nomem ||
          errno == error_io)
        strerr_die4sys(111,FATAL,ERR_EXECUTE,sendargs[2],": ");
      else
        strerr_die4sys(100,FATAL,ERR_EXECUTE,sendargs[2],": ");
   }
         /* parent */
   wait_pid(&wstat,child);
   if (wait_crashed(wstat))
     strerr_die2x(111,FATAL,ERR_CHILD_CRASHED);
   switch(wait_exitcode(wstat)) {
     case 100:
       strerr_die2x(100,FATAL,ERR_CHILD_FATAL);
     case 111:
        strerr_die2x(111,FATAL,ERR_CHILD_TEMP);
     case 0:
       _exit(0);
     default:
       strerr_die2x(111,FATAL,ERR_CHILD_UNKNOWN);
   }
}