chiark - git - mdw - qmail/blob - condredirect.c

   1 #include "sig.h"
   2 #include "readwrite.h"
   3 #include "exit.h"
   4 #include "env.h"
   5 #include "error.h"
   6 #include "fork.h"
   7 #include "wait.h"
   8 #include "seek.h"
   9 #include "qmail.h"
  10 #include "strerr.h"
  11 #include "substdio.h"
  12 #include "fmt.h"
  13
  14 #define FATAL "condredirect: fatal: "
  15
  16 struct qmail qqt;
  17
  18 int mywrite(fd,buf,len) int fd; char *buf; int len;
  19 {
  20   qmail_put(&qqt,buf,len);
  21   return len;
  22 }
  23
  24 char inbuf[SUBSTDIO_INSIZE];
  25 char outbuf[1];
  26 substdio ssin = SUBSTDIO_FDBUF(read,0,inbuf,sizeof inbuf);
  27 substdio ssout = SUBSTDIO_FDBUF(mywrite,-1,outbuf,sizeof outbuf);
  28
  29 char num[FMT_ULONG];
  30
  31 void main(argc,argv)
  32 int argc;
  33 char **argv;
  34 {
  35   char *sender;
  36   char *dtline;
  37   int pid;
  38   int wstat;
  39   char *qqx;
  40
  41   if (!argv[1] || !argv[2])
  42     strerr_die1x(100,"condredirect: usage: condredirect newaddress program [ arg ... ]");
  43
  44   pid = fork();
  45   if (pid == -1)
  46     strerr_die2sys(111,FATAL,"unable to fork: ");
  47   if (pid == 0) {
  48     execvp(argv[2],argv + 2);
  49     if (error_temp(errno)) _exit(111);
  50     _exit(100);
  51   }
  52   if (wait_pid(&wstat,pid) == -1)
  53     strerr_die2x(111,FATAL,"wait failed");
  54   if (wait_crashed(wstat))
  55     strerr_die2x(111,FATAL,"child crashed");
  56   switch(wait_exitcode(wstat)) {
  57     case 0: break;
  58     case 111: strerr_die2x(111,FATAL,"temporary child error");
  59     default: _exit(0);
  60   }
  61
  62   if (seek_begin(0) == -1)
  63     strerr_die2sys(111,FATAL,"unable to rewind: ");
  64   sig_pipeignore();
  65
  66   sender = env_get("SENDER");
  67   if (!sender) strerr_die2x(100,FATAL,"SENDER not set");
  68   dtline = env_get("DTLINE");
  69   if (!dtline) strerr_die2x(100,FATAL,"DTLINE not set");
  70
  71   if (qmail_open(&qqt) == -1)
  72     strerr_die2sys(111,FATAL,"unable to fork: ");
  73   qmail_puts(&qqt,dtline);
  74   if (substdio_copy(&ssout,&ssin) != 0)
  75     strerr_die2sys(111,FATAL,"unable to read message: ");
  76   substdio_flush(&ssout);
  77
  78   num[fmt_ulong(num,qmail_qp(&qqt))] = 0;
  79
  80   qmail_from(&qqt,sender);
  81   qmail_to(&qqt,argv[1]);
  82   qqx = qmail_close(&qqt);
  83   if (*qqx) strerr_die2x(*qqx == 'D' ? 100 : 111,FATAL,qqx + 1);
  84   strerr_die2x(99,"condredirect: qp ",num);
  85 }