1 #include <sys/types.h>

     2 #include <sys/stat.h>

     3 #include "readwrite.h"

     4 #include "sig.h"

     5 #include "env.h"

     6 #include "byte.h"

     7 #include "exit.h"

     8 #include "fork.h"

     9 #include "open.h"

    10 #include "wait.h"

    11 #include "lock.h"

    12 #include "seek.h"

    13 #include "substdio.h"

    14 #include "getln.h"

    15 #include "strerr.h"

    16 #include "subfd.h"

    17 #include "sgetopt.h"

    18 #include "alloc.h"

    19 #include "error.h"

    20 #include "stralloc.h"

    21 #include "fmt.h"

    22 #include "str.h"

    23 #include "now.h"

    24 #include "case.h"

    25 #include "quote.h"

    26 #include "qmail.h"

    27 #include "slurpclose.h"

    28 #include "myctime.h"

    29 #include "gfrom.h"

    30 #include "auto_patrn.h"

    31 

    32 void usage() { strerr_die1x(100,"qmail-local: usage: qmail-local [ -nN ] user homedir local dash ext domain sender aliasempty"); }

    33 

    34 void temp_nomem() { strerr_die1x(111,"Out of memory. (#4.3.0)"); }

    35 void temp_rewind() { strerr_die1x(111,"Unable to rewind message. (#4.3.0)"); }

    36 void temp_childcrashed() { strerr_die1x(111,"Aack, child crashed. (#4.3.0)"); }

    37 void temp_fork() { strerr_die3x(111,"Unable to fork: ",error_str(errno),". (#4.3.0)"); }

    38 void temp_read() { strerr_die3x(111,"Unable to read message: ",error_str(errno),". (#4.3.0)"); }

    39 void temp_slowlock()

    40 { strerr_die1x(111,"File has been locked for 30 seconds straight. (#4.3.0)"); }

    41 void temp_qmail(fn) char *fn;

    42 { strerr_die5x(111,"Unable to open ",fn,": ",error_str(errno),". (#4.3.0)"); }

    43 

    44 int flagdoit;

    45 int flag99;

    46 

    47 char *user;

    48 char *homedir;

    49 char *local;

    50 char *dash;

    51 char *ext;

    52 char *host;

    53 char *sender;

    54 char *aliasempty;

    55 

    56 stralloc safeext = {0};

    57 stralloc ufline = {0};

    58 stralloc rpline = {0};

    59 stralloc envrecip = {0};

    60 stralloc dtline = {0};

    61 stralloc qme = {0};

    62 stralloc ueo = {0};

    63 stralloc cmds = {0};

    64 stralloc messline = {0};

    65 stralloc foo = {0};

    66 

    67 char buf[1024];

    68 char outbuf[1024];

    69 

    70 /* child process */

    71 

    72 char fntmptph[80 + FMT_ULONG * 2];

    73 char fnnewtph[80 + FMT_ULONG * 2];

    74 void tryunlinktmp() { unlink(fntmptph); }

    75 void sigalrm() { tryunlinktmp(); _exit(3); }

    76 

    77 void maildir_child(dir)

    78 char *dir;

    79 {

    80  unsigned long pid;

    81  unsigned long time;

    82  char host[64];

    83  char *s;

    84  int loop;

    85  struct stat st;

    86  int fd;

    87  substdio ss;

    88  substdio ssout;

    89 

    90  sig_alarmcatch(sigalrm);

    91  if (chdir(dir) == -1) { if (error_temp(errno)) _exit(1); _exit(2); }

    92  pid = getpid();

    93  host[0] = 0;

    94  gethostname(host,sizeof(host));

    95  for (loop = 0;;++loop)

    96   {

    97    time = now();

    98    s = fntmptph;

    99    s += fmt_str(s,"tmp/");

   100    s += fmt_ulong(s,time); *s++ = '.';

   101    s += fmt_ulong(s,pid); *s++ = '.';

   102    s += fmt_strn(s,host,sizeof(host)); *s++ = 0;

   103    if (stat(fntmptph,&st) == -1) if (errno == error_noent) break;

   104    /* really should never get to this point */

   105    if (loop == 2) _exit(1);

   106    sleep(2);

   107   }

   108  str_copy(fnnewtph,fntmptph);

   109  byte_copy(fnnewtph,3,"new");

   110 

   111  alarm(86400);

   112  fd = open_excl(fntmptph);

   113  if (fd == -1) _exit(1);

   114 

   115  substdio_fdbuf(&ss,read,0,buf,sizeof(buf));

   116  substdio_fdbuf(&ssout,write,fd,outbuf,sizeof(outbuf));

   117  if (substdio_put(&ssout,rpline.s,rpline.len) == -1) goto fail;

   118  if (substdio_put(&ssout,dtline.s,dtline.len) == -1) goto fail;

   119 

   120  switch(substdio_copy(&ssout,&ss))

   121   {

   122    case -2: tryunlinktmp(); _exit(4);

   123    case -3: goto fail;

   124   }

   125 

   126  if (substdio_flush(&ssout) == -1) goto fail;

   127  if (fsync(fd) == -1) goto fail;

   128  if (close(fd) == -1) goto fail; /* NFS dorks */

   129 

   130  if (link(fntmptph,fnnewtph) == -1) goto fail;

   131    /* if it was error_exist, almost certainly successful; i hate NFS */

   132  tryunlinktmp(); _exit(0);

   133 

   134  fail: tryunlinktmp(); _exit(1);

   135 }

   136 

   137 /* end child process */

   138 

   139 void maildir(fn)

   140 char *fn;

   141 {

   142  int child;

   143  int wstat;

   144 

   145  if (seek_begin(0) == -1) temp_rewind();

   146 

   147  switch(child = fork())

   148   {

   149    case -1:

   150      temp_fork();

   151    case 0:

   152      maildir_child(fn);

   153      _exit(111);

   154   }

   155 

   156  wait_pid(&wstat,child);

   157  if (wait_crashed(wstat))

   158    temp_childcrashed();

   159  switch(wait_exitcode(wstat))

   160   {

   161    case 0: break;

   162    case 2: strerr_die1x(111,"Unable to chdir to maildir. (#4.2.1)");

   163    case 3: strerr_die1x(111,"Timeout on maildir delivery. (#4.3.0)");

   164    case 4: strerr_die1x(111,"Unable to read message. (#4.3.0)");

   165    default: strerr_die1x(111,"Temporary error on maildir delivery. (#4.3.0)");

   166   }

   167 }

   168 

   169 void mailfile(fn)

   170 char *fn;

   171 {

   172  int fd;

   173  substdio ss;

   174  substdio ssout;

   175  int match;

   176  seek_pos pos;

   177  int flaglocked;

   178 

   179  if (seek_begin(0) == -1) temp_rewind();

   180 

   181  fd = open_append(fn);

   182  if (fd == -1)

   183    strerr_die5x(111,"Unable to open ",fn,": ",error_str(errno),". (#4.2.1)");

   184 

   185  sig_alarmcatch(temp_slowlock);

   186  alarm(30);

   187  flaglocked = (lock_ex(fd) != -1);

   188  alarm(0);

   189  sig_alarmdefault();

   190 

   191  seek_end(fd);

   192  pos = seek_cur(fd);

   193 

   194  substdio_fdbuf(&ss,read,0,buf,sizeof(buf));

   195  substdio_fdbuf(&ssout,write,fd,outbuf,sizeof(outbuf));

   196  if (substdio_put(&ssout,ufline.s,ufline.len)) goto writeerrs;

   197  if (substdio_put(&ssout,rpline.s,rpline.len)) goto writeerrs;

   198  if (substdio_put(&ssout,dtline.s,dtline.len)) goto writeerrs;

   199  for (;;)

   200   {

   201    if (getln(&ss,&messline,&match,'\n') != 0) 

   202     {

   203      strerr_warn3("Unable to read message: ",error_str(errno),". (#4.3.0)",0);

   204      if (flaglocked) seek_trunc(fd,pos); close(fd);

   205      _exit(111);

   206     }

   207    if (!match && !messline.len) break;

   208    if (gfrom(messline.s,messline.len))

   209      if (substdio_bput(&ssout,">",1)) goto writeerrs;

   210    if (substdio_bput(&ssout,messline.s,messline.len)) goto writeerrs;

   211    if (!match)

   212     {

   213      if (substdio_bputs(&ssout,"\n")) goto writeerrs;

   214      break;

   215     }

   216   }

   217  if (substdio_bputs(&ssout,"\n")) goto writeerrs;

   218  if (substdio_flush(&ssout)) goto writeerrs;

   219  if (fsync(fd) == -1) goto writeerrs;

   220  close(fd);

   221  return;

   222 

   223  writeerrs:

   224  strerr_warn5("Unable to write ",fn,": ",error_str(errno),". (#4.3.0)",0);

   225  if (flaglocked) seek_trunc(fd,pos);

   226  close(fd);

   227  _exit(111);

   228 }

   229 

   230 void mailprogram(prog)

   231 char *prog;

   232 {

   233  int child;

   234  char *(args[4]);

   235  int wstat;

   236 

   237  if (seek_begin(0) == -1) temp_rewind();

   238 

   239  switch(child = fork())

   240   {

   241    case -1:

   242      temp_fork();

   243    case 0:

   244      args[0] = "/bin/sh"; args[1] = "-c"; args[2] = prog; args[3] = 0;

   245      sig_pipedefault();

   246      execv(*args,args);

   247      strerr_die3x(111,"Unable to run /bin/sh: ",error_str(errno),". (#4.3.0)");

   248   }

   249 

   250  wait_pid(&wstat,child);

   251  if (wait_crashed(wstat))

   252    temp_childcrashed();

   253  switch(wait_exitcode(wstat))

   254   {

   255    case 100:

   256    case 64: case 65: case 70: case 76: case 77: case 78: case 112: _exit(100);

   257    case 0: break;

   258    case 99: flag99 = 1; break;

   259    default: _exit(111);

   260   }

   261 }

   262 

   263 unsigned long mailforward_qp = 0;

   264 

   265 void mailforward(recips)

   266 char **recips;

   267 {

   268  struct qmail qqt;

   269  char *qqx;

   270  substdio ss;

   271  int match;

   272 

   273  if (seek_begin(0) == -1) temp_rewind();

   274  substdio_fdbuf(&ss,read,0,buf,sizeof(buf));

   275 

   276  if (qmail_open(&qqt) == -1) temp_fork();

   277  mailforward_qp = qmail_qp(&qqt);

   278  qmail_put(&qqt,dtline.s,dtline.len);

   279  do

   280   {

   281    if (getln(&ss,&messline,&match,'\n') != 0) { qmail_fail(&qqt); break; }

   282    qmail_put(&qqt,messline.s,messline.len);

   283   }

   284  while (match);

   285  qmail_from(&qqt,ueo.s);

   286  while (*recips) qmail_to(&qqt,*recips++);

   287  qqx = qmail_close(&qqt);

   288  if (!*qqx) return;

   289  strerr_die3x(*qqx == 'D' ? 100 : 111,"Unable to forward message: ",qqx + 1,".");

   290 }

   291 

   292 void bouncexf()

   293 {

   294  int match;

   295  substdio ss;

   296 

   297  if (seek_begin(0) == -1) temp_rewind();

   298  substdio_fdbuf(&ss,read,0,buf,sizeof(buf));

   299  for (;;)

   300   {

   301    if (getln(&ss,&messline,&match,'\n') != 0) temp_read();

   302    if (!match) break;

   303    if (messline.len <= 1)

   304      break;

   305    if (messline.len == dtline.len)

   306      if (!str_diffn(messline.s,dtline.s,dtline.len))

   307        strerr_die1x(100,"This message is looping: it already has my Delivered-To line. (#5.4.6)");

   308   }

   309 }

   310 

   311 void checkhome()

   312 {

   313  struct stat st;

   314 

   315  if (stat(".",&st) == -1)

   316    strerr_die3x(111,"Unable to stat home directory: ",error_str(errno),". (#4.3.0)");

   317  if (st.st_mode & auto_patrn)

   318    strerr_die1x(111,"Uh-oh: home directory is writable. (#4.7.0)");

   319  if (st.st_mode & 01000)

   320    if (flagdoit)

   321      strerr_die1x(111,"Home directory is sticky: user is editing his .qmail file. (#4.2.1)");

   322    else

   323      strerr_warn1("Warning: home directory is sticky.",0);

   324 }

   325 

   326 int qmeox(dashowner)

   327 char *dashowner;

   328 {

   329  struct stat st;

   330 

   331  if (!stralloc_copys(&qme,".qmail")) temp_nomem();

   332  if (!stralloc_cats(&qme,dash)) temp_nomem();

   333  if (!stralloc_cat(&qme,&safeext)) temp_nomem();

   334  if (!stralloc_cats(&qme,dashowner)) temp_nomem();

   335  if (!stralloc_0(&qme)) temp_nomem();

   336  if (stat(qme.s,&st) == -1)

   337   {

   338    if (error_temp(errno)) temp_qmail(qme.s);

   339    return -1;

   340   }

   341  return 0;

   342 }

   343 

   344 int qmeexists(fd,cutable)

   345 int *fd;

   346 int *cutable;

   347 {

   348   struct stat st;

   349 

   350   if (!stralloc_0(&qme)) temp_nomem();

   351 

   352   *fd = open_read(qme.s);

   353   if (*fd == -1) {

   354     if (error_temp(errno)) temp_qmail(qme.s);

   355     if (errno == error_perm) temp_qmail(qme.s);

   356     if (errno == error_acces) temp_qmail(qme.s);

   357     return 0;

   358   }

   359 

   360   if (fstat(*fd,&st) == -1) temp_qmail(qme.s);

   361   if ((st.st_mode & S_IFMT) == S_IFREG) {

   362     if (st.st_mode & auto_patrn)

   363       strerr_die1x(111,"Uh-oh: .qmail file is writable. (#4.7.0)");

   364     *cutable = !!(st.st_mode & 0100);

   365     return 1;

   366   }

   367   close(*fd);

   368   return 0;

   369 }

   370 

   371 /* "" "": "" */

   372 /* "-/" "": "-/" "-/default" */

   373 /* "-/" "a": "-/a" "-/default" */

   374 /* "-/" "a-": "-/a-" "-/a-default" "-/default" */

   375 /* "-/" "a-b": "-/a-b" "-/a-default" "-/default" */

   376 /* "-/" "a-b-": "-/a-b-" "-/a-b-default" "-/a-default" "-/default" */

   377 /* "-/" "a-b-c": "-/a-b-c" "-/a-b-default" "-/a-default" "-/default" */

   378 

   379 void qmesearch(fd,cutable)

   380 int *fd;

   381 int *cutable;

   382 {

   383   int i;

   384 

   385   if (!stralloc_copys(&qme,".qmail")) temp_nomem();

   386   if (!stralloc_cats(&qme,dash)) temp_nomem();

   387   if (!stralloc_cat(&qme,&safeext)) temp_nomem();

   388   if (qmeexists(fd,cutable)) {

   389     if (safeext.len >= 7) {

   390       i = safeext.len - 7;

   391       if (!byte_diff("default",7,safeext.s + i))

   392 	if (i <= str_len(ext)) /* paranoia */

   393 	  if (!env_put2("DEFAULT",ext + i)) temp_nomem();

   394     }

   395     return;

   396   }

   397 

   398   for (i = safeext.len;i >= 0;--i)

   399     if (!i || (safeext.s[i - 1] == '-')) {

   400       if (!stralloc_copys(&qme,".qmail")) temp_nomem();

   401       if (!stralloc_cats(&qme,dash)) temp_nomem();

   402       if (!stralloc_catb(&qme,safeext.s,i)) temp_nomem();

   403       if (!stralloc_cats(&qme,"default")) temp_nomem();

   404       if (qmeexists(fd,cutable)) {

   405 	if (i <= str_len(ext)) /* paranoia */

   406 	  if (!env_put2("DEFAULT",ext + i)) temp_nomem();

   407         return;

   408       }

   409     }

   410 

   411   *fd = -1;

   412 }

   413 

   414 unsigned long count_file = 0;

   415 unsigned long count_forward = 0;

   416 unsigned long count_program = 0;

   417 char count_buf[FMT_ULONG];

   418 

   419 void count_print()

   420 {

   421  substdio_puts(subfdoutsmall,"did ");

   422  substdio_put(subfdoutsmall,count_buf,fmt_ulong(count_buf,count_file));

   423  substdio_puts(subfdoutsmall,"+");

   424  substdio_put(subfdoutsmall,count_buf,fmt_ulong(count_buf,count_forward));

   425  substdio_puts(subfdoutsmall,"+");

   426  substdio_put(subfdoutsmall,count_buf,fmt_ulong(count_buf,count_program));

   427  substdio_puts(subfdoutsmall,"\n");

   428  if (mailforward_qp)

   429   {

   430    substdio_puts(subfdoutsmall,"qp ");

   431    substdio_put(subfdoutsmall,count_buf,fmt_ulong(count_buf,mailforward_qp));

   432    substdio_puts(subfdoutsmall,"\n");

   433   }

   434  substdio_flush(subfdoutsmall);

   435 }

   436 

   437 void sayit(type,cmd,len)

   438 char *type;

   439 char *cmd;

   440 int len;

   441 {

   442  substdio_puts(subfdoutsmall,type);

   443  substdio_put(subfdoutsmall,cmd,len);

   444  substdio_putsflush(subfdoutsmall,"\n");

   445 }

   446 

   447 void main(argc,argv)

   448 int argc;

   449 char **argv;

   450 {

   451  int opt;

   452  int i;

   453  int j;

   454  int k;

   455  int fd;

   456  int numforward;

   457  char **recips;

   458  datetime_sec starttime;

   459  int flagforwardonly;

   460  char *x;

   461 

   462  umask(077);

   463  sig_pipeignore();

   464 

   465  if (!env_init()) temp_nomem();

   466 

   467  flagdoit = 1;

   468  while ((opt = getopt(argc,argv,"nN")) != opteof)

   469    switch(opt)

   470     {

   471      case 'n': flagdoit = 0; break;

   472      case 'N': flagdoit = 1; break;

   473      default:

   474        usage();

   475     }

   476  argc -= optind;

   477  argv += optind;

   478 

   479  if (!(user = *argv++)) usage();

   480  if (!(homedir = *argv++)) usage();

   481  if (!(local = *argv++)) usage();

   482  if (!(dash = *argv++)) usage();

   483  if (!(ext = *argv++)) usage();

   484  if (!(host = *argv++)) usage();

   485  if (!(sender = *argv++)) usage();

   486  if (!(aliasempty = *argv++)) usage();

   487  if (*argv) usage();

   488 

   489  if (homedir[0] != '/') usage();

   490  if (chdir(homedir) == -1)

   491    strerr_die5x(111,"Unable to switch to ",homedir,": ",error_str(errno),". (#4.3.0)");

   492  checkhome();

   493 

   494  if (!env_put2("HOST",host)) temp_nomem();

   495  if (!env_put2("HOME",homedir)) temp_nomem();

   496  if (!env_put2("USER",user)) temp_nomem();

   497  if (!env_put2("LOCAL",local)) temp_nomem();

   498 

   499  if (!stralloc_copys(&envrecip,local)) temp_nomem();

   500  if (!stralloc_cats(&envrecip,"@")) temp_nomem();

   501  if (!stralloc_cats(&envrecip,host)) temp_nomem();

   502 

   503  if (!stralloc_copy(&foo,&envrecip)) temp_nomem();

   504  if (!stralloc_0(&foo)) temp_nomem();

   505  if (!env_put2("RECIPIENT",foo.s)) temp_nomem();

   506 

   507  if (!stralloc_copys(&dtline,"Delivered-To: ")) temp_nomem();

   508  if (!stralloc_cat(&dtline,&envrecip)) temp_nomem();

   509  for (i = 0;i < dtline.len;++i) if (dtline.s[i] == '\n') dtline.s[i] = '_';

   510  if (!stralloc_cats(&dtline,"\n")) temp_nomem();

   511 

   512  if (!stralloc_copy(&foo,&dtline)) temp_nomem();

   513  if (!stralloc_0(&foo)) temp_nomem();

   514  if (!env_put2("DTLINE",foo.s)) temp_nomem();

   515 

   516  if (flagdoit)

   517    bouncexf();

   518 

   519  if (!env_put2("SENDER",sender)) temp_nomem();

   520 

   521  if (!quote2(&foo,sender)) temp_nomem();

   522  if (!stralloc_copys(&rpline,"Return-Path: <")) temp_nomem();

   523  if (!stralloc_cat(&rpline,&foo)) temp_nomem();

   524  for (i = 0;i < rpline.len;++i) if (rpline.s[i] == '\n') rpline.s[i] = '_';

   525  if (!stralloc_cats(&rpline,">\n")) temp_nomem();

   526 

   527  if (!stralloc_copy(&foo,&rpline)) temp_nomem();

   528  if (!stralloc_0(&foo)) temp_nomem();

   529  if (!env_put2("RPLINE",foo.s)) temp_nomem();

   530 

   531  if (!stralloc_copys(&ufline,"From ")) temp_nomem();

   532  if (*sender)

   533   {

   534    int len; int i; char ch;

   535 

   536    len = str_len(sender);

   537    if (!stralloc_readyplus(&ufline,len)) temp_nomem();

   538    for (i = 0;i < len;++i)

   539     {

   540      ch = sender[i];

   541      if ((ch == ' ') || (ch == '\t') || (ch == '\n')) ch = '-';

   542      ufline.s[ufline.len + i] = ch;

   543     }

   544    ufline.len += len;

   545   }

   546  else

   547    if (!stralloc_cats(&ufline,"MAILER-DAEMON")) temp_nomem();

   548  if (!stralloc_cats(&ufline," ")) temp_nomem();

   549  starttime = now();

   550  if (!stralloc_cats(&ufline,myctime(starttime))) temp_nomem();

   551 

   552  if (!stralloc_copy(&foo,&ufline)) temp_nomem();

   553  if (!stralloc_0(&foo)) temp_nomem();

   554  if (!env_put2("UFLINE",foo.s)) temp_nomem();

   555 

   556  x = ext;

   557  if (!env_put2("EXT",x)) temp_nomem();

   558  x += str_chr(x,'-'); if (*x) ++x;

   559  if (!env_put2("EXT2",x)) temp_nomem();

   560  x += str_chr(x,'-'); if (*x) ++x;

   561  if (!env_put2("EXT3",x)) temp_nomem();

   562  x += str_chr(x,'-'); if (*x) ++x;

   563  if (!env_put2("EXT4",x)) temp_nomem();

   564 

   565  if (!stralloc_copys(&safeext,ext)) temp_nomem();

   566  case_lowerb(safeext.s,safeext.len);

   567  for (i = 0;i < safeext.len;++i)

   568    if (safeext.s[i] == '.')

   569      safeext.s[i] = ':';

   570 

   571  i = str_len(host);

   572  i = byte_rchr(host,i,'.');

   573  if (!stralloc_copyb(&foo,host,i)) temp_nomem();

   574  if (!stralloc_0(&foo)) temp_nomem();

   575  if (!env_put2("HOST2",foo.s)) temp_nomem();

   576  i = byte_rchr(host,i,'.');

   577  if (!stralloc_copyb(&foo,host,i)) temp_nomem();

   578  if (!stralloc_0(&foo)) temp_nomem();

   579  if (!env_put2("HOST3",foo.s)) temp_nomem();

   580  i = byte_rchr(host,i,'.');

   581  if (!stralloc_copyb(&foo,host,i)) temp_nomem();

   582  if (!stralloc_0(&foo)) temp_nomem();

   583  if (!env_put2("HOST4",foo.s)) temp_nomem();

   584 

   585  flagforwardonly = 0;

   586  qmesearch(&fd,&flagforwardonly);

   587  if (fd == -1)

   588    if (*dash)

   589      strerr_die1x(100,"Sorry, no mailbox here by that name. (#5.1.1)");

   590 

   591  if (!stralloc_copys(&ueo,sender)) temp_nomem();

   592  if (str_diff(sender,""))

   593    if (str_diff(sender,"#@[]"))

   594      if (qmeox("-owner") == 0)

   595       {

   596        if (qmeox("-owner-default") == 0)

   597 	{

   598          if (!stralloc_copys(&ueo,local)) temp_nomem();

   599          if (!stralloc_cats(&ueo,"-owner-@")) temp_nomem();

   600          if (!stralloc_cats(&ueo,host)) temp_nomem();

   601          if (!stralloc_cats(&ueo,"-@[]")) temp_nomem();

   602 	}

   603        else

   604 	{

   605          if (!stralloc_copys(&ueo,local)) temp_nomem();

   606          if (!stralloc_cats(&ueo,"-owner@")) temp_nomem();

   607          if (!stralloc_cats(&ueo,host)) temp_nomem();

   608 	}

   609       }

   610  if (!stralloc_0(&ueo)) temp_nomem();

   611  if (!env_put2("NEWSENDER",ueo.s)) temp_nomem();

   612 

   613  if (!stralloc_ready(&cmds,0)) temp_nomem();

   614  cmds.len = 0;

   615  if (fd != -1)

   616    if (slurpclose(fd,&cmds,256) == -1) temp_nomem();

   617 

   618  if (!cmds.len)

   619   {

   620    if (!stralloc_copys(&cmds,aliasempty)) temp_nomem();

   621    flagforwardonly = 0;

   622   }

   623  if (!cmds.len || (cmds.s[cmds.len - 1] != '\n'))

   624    if (!stralloc_cats(&cmds,"\n")) temp_nomem();

   625 

   626  numforward = 0;

   627  i = 0;

   628  for (j = 0;j < cmds.len;++j)

   629    if (cmds.s[j] == '\n')

   630     {

   631      switch(cmds.s[i]) { case '#': case '.': case '/': case '|': break;

   632        default: ++numforward; }

   633      i = j + 1;

   634     }

   635 

   636  recips = (char **) alloc((numforward + 1) * sizeof(char *));

   637  if (!recips) temp_nomem();

   638  numforward = 0;

   639 

   640  flag99 = 0;

   641 

   642  i = 0;

   643  for (j = 0;j < cmds.len;++j)

   644    if (cmds.s[j] == '\n')

   645     {

   646      cmds.s[j] = 0;

   647      k = j;

   648      while ((k > i) && (cmds.s[k - 1] == ' ') || (cmds.s[k - 1] == '\t'))

   649        cmds.s[--k] = 0;

   650      switch(cmds.s[i])

   651       {

   652        case 0: /* k == i */

   653 	 if (i) break;

   654          strerr_die1x(111,"Uh-oh: first line of .qmail file is blank. (#4.2.1)");

   655        case '#':

   656          break;

   657        case '.':

   658        case '/':

   659 	 ++count_file;

   660 	 if (flagforwardonly) strerr_die1x(111,"Uh-oh: .qmail has file delivery but has x bit set. (#4.7.0)");

   661 	 if (cmds.s[k - 1] == '/')

   662            if (flagdoit) maildir(cmds.s + i);

   663            else sayit("maildir ",cmds.s + i,k - i);

   664 	 else

   665            if (flagdoit) mailfile(cmds.s + i);

   666            else sayit("mbox ",cmds.s + i,k - i);

   667          break;

   668        case '|':

   669 	 ++count_program;

   670 	 if (flagforwardonly) strerr_die1x(111,"Uh-oh: .qmail has prog delivery but has x bit set. (#4.7.0)");

   671          if (flagdoit) mailprogram(cmds.s + i + 1);

   672          else sayit("program ",cmds.s + i + 1,k - i - 1);

   673          break;

   674        case '+':

   675 	 if (str_equal(cmds.s + i + 1,"list"))

   676 	   flagforwardonly = 1;

   677 	 break;

   678        case '&':

   679          ++i;

   680        default:

   681 	 ++count_forward;

   682          if (flagdoit) recips[numforward++] = cmds.s + i;

   683          else sayit("forward ",cmds.s + i,k - i);

   684          break;

   685       }

   686      i = j + 1;

   687      if (flag99) break;

   688     }

   689 

   690  if (numforward) if (flagdoit)

   691   {

   692    recips[numforward] = 0;

   693    mailforward(recips);

   694   }

   695 

   696  count_print();

   697  _exit(0);

   698 }