git.marmaro.de Git - mmh/blob - uip/repl.c

   1 /*
   2 ** repl.c -- reply to a message
   3 **
   4 ** This code is Copyright (c) 2002, by the authors of nmh.  See the
   5 ** COPYRIGHT file in the root directory of the nmh distribution for
   6 ** complete copyright information.
   7 */
   8
   9 #include <h/mh.h>
  10 #include <h/utils.h>
  11 #include <h/addrsbr.h>
  12 #include <h/fmt_scan.h>
  13 #include <sys/file.h>  /* L_SET */
  14 #include <errno.h>
  15 #include <unistd.h>
  16 #include <ctype.h>
  17 #include <sys/stat.h>
  18 #include <locale.h>
  19 #include <sysexits.h>
  20
  21 static struct swit switches[] = {
  22 #define GROUPSW  0
  23         { "group", 0 },
  24 #define NGROUPSW  1
  25         { "nogroup", 2 },
  26 #define ANNOSW  2
  27         { "annotate", 0 },
  28 #define NANNOSW  3
  29         { "noannotate", 2 },
  30 #define CCSW  4
  31         { "cc all|to|cc|me", 0 },
  32 #define NCCSW  5
  33         { "nocc type", 2 },
  34 #define EDITRSW  6
  35         { "editor editor", 0 },
  36 #define FILTSW  7
  37         { "filter filterfile", 0 },
  38 #define NFILTSW  8
  39         { "nofilter", 2 },
  40 #define FORMSW  9
  41         { "form formfile", 0 },
  42 #define MIMESW  10
  43         { "mime", 0 },
  44 #define NMIMESW  11
  45         { "nomime", 2 },
  46 #define QURYSW  12
  47         { "query", 0 },
  48 #define NQURYSW  13
  49         { "noquery", 2 },
  50 #define WHATSW  14
  51         { "whatnowproc program", 0 },
  52 #define VERSIONSW  15
  53         { "Version", 0 },
  54 #define HELPSW  16
  55         { "help", 0 },
  56 #define FILESW  17
  57         { "file file", 4 },  /* interface from msh */
  58 #define BILDSW  18
  59         { "build", 5 },  /* interface from mhe */
  60         { NULL, 0 }
  61 };
  62
  63 static struct swit ccswitches[] = {
  64 #define CTOSW  0
  65         { "to", 0 },
  66 #define CCCSW  1
  67         { "cc", 0 },
  68 #define CMESW  2
  69         { "me", 0 },
  70 #define CALSW  3
  71         { "all", 0 },
  72         { NULL, 0 }
  73 };
  74
  75 /*
  76 ** Buffer size for content part of header fields.
  77 ** We want this to be large enough so that we don't
  78 ** do a lot of extra FLDPLUS calls on m_getfld but
  79 ** small enough so that we don't snarf the entire
  80 ** message body when we're not going to use any of it.
  81 */
  82 #define SBUFSIZ 256
  83
  84 static short ccto = -1;
  85 static short cccc = -1;
  86 static short ccme = -1;
  87 static short querysw = 0;
  88
  89 static short groupreply = 0;  /* Is this a group reply? */
  90
  91 static int mime = 0;  /* include original as MIME part */
  92 static char *form   = NULL;  /* form (components) file */
  93 static char *filter = NULL;  /* message filter file */
  94
  95 static int dftype=0;
  96
  97 static char *badaddrs = NULL;
  98 static char *dfhost = NULL;
  99
 100 static struct mailname mq;
 101
 102 static struct format *fmt;
 103
 104 static int ncomps = 0;  /* # of interesting components */
 105 static char **compbuffers = NULL;  /* buffers for component text */
 106 static struct comp **used_buf = NULL;  /* stack for comp that use buffers */
 107
 108 static int dat[5];  /* aux. data for format routine */
 109
 110 static char *addrcomps[] = {
 111         "from",
 112         "sender",
 113         "reply-to",
 114         "to",
 115         "cc",
 116         "bcc",
 117         "resent-from",
 118         "resent-sender",
 119         "resent-reply-to",
 120         "resent-to",
 121         "resent-cc",
 122         "resent-bcc",
 123         NULL
 124 };
 125
 126 /*
 127 ** static prototypes
 128 */
 129 static void docc(char *, int);
 130 static int insert(struct mailname *);
 131 static void replfilter(FILE *, FILE *, char *);
 132 static void replout(FILE *, char *, struct msgs *, int,
 133                 char *, char *);
 134
 135
 136 int
 137 main(int argc, char **argv)
 138 {
 139         int anot = 0;
 140         char *cp, *cwd, *maildir, *file = NULL;
 141         char *folder = NULL, *msg = NULL;
 142         char *ed = NULL, drft[BUFSIZ], buf[BUFSIZ];
 143         char **argp, **arguments;
 144         struct msgs *mp = NULL;
 145         FILE *in;
 146         int buildsw = 0;
 147
 148         setlocale(LC_ALL, "");
 149         invo_name = mhbasename(argv[0]);
 150
 151         /* read user profile/context */
 152         context_read();
 153
 154         filter = getcpy(etcpath(mhlreply));
 155
 156         arguments = getarguments(invo_name, argc, argv, 1);
 157         argp = arguments;
 158
 159         while ((cp = *argp++)) {
 160                 if (*cp == '-') {
 161                         switch (smatch(++cp, switches)) {
 162                         case AMBIGSW:
 163                                 ambigsw(cp, switches);
 164                                 exit(EX_USAGE);
 165                         case UNKWNSW:
 166                                 adios(EX_USAGE, NULL, "-%s unknown", cp);
 167
 168                         case HELPSW:
 169                                 snprintf(buf, sizeof(buf), "%s: [+folder] [msg] [switches]", invo_name);
 170                                 print_help(buf, switches, 1);
 171                                 exit(argc == 2 ? EX_OK : EX_USAGE);
 172                         case VERSIONSW:
 173                                 print_version(invo_name);
 174                                 exit(argc == 2 ? EX_OK : EX_USAGE);
 175
 176                         case GROUPSW:
 177                                 groupreply++;
 178                                 continue;
 179                         case NGROUPSW:
 180                                 groupreply = 0;
 181                                 continue;
 182
 183                         case ANNOSW:
 184                                 anot++;
 185                                 continue;
 186                         case NANNOSW:
 187                                 anot = 0;
 188                                 continue;
 189
 190                         case CCSW:
 191                                 if (!(cp = *argp++) || *cp == '-')
 192                                         adios(EX_USAGE, NULL, "missing argument to %s",
 193                                                         argp[-2]);
 194                                 docc(cp, 1);
 195                                 continue;
 196                         case NCCSW:
 197                                 if (!(cp = *argp++) || *cp == '-')
 198                                         adios(EX_USAGE, NULL, "missing argument to %s",
 199                                                         argp[-2]);
 200                                 docc(cp, 0);
 201                                 continue;
 202
 203                         case EDITRSW:
 204                                 if (!(ed = *argp++) || *ed == '-')
 205                                         adios(EX_USAGE, NULL, "missing argument to %s",
 206                                                         argp[-2]);
 207                                 continue;
 208
 209                         case WHATSW:
 210                                 if (!(whatnowproc = *argp++) ||
 211                                                 *whatnowproc == '-')
 212                                         adios(EX_USAGE, NULL, "missing argument to %s",
 213                                                         argp[-2]);
 214                                 continue;
 215
 216                         case BILDSW:
 217                                 buildsw++;
 218                                 continue;
 219
 220                         case FILESW:
 221                                 if (file)
 222                                         adios(EX_USAGE, NULL, "only one file at a time!");
 223                                 if (!(cp = *argp++) || *cp == '-')
 224                                         adios(EX_USAGE, NULL, "missing argument to %s",
 225                                                         argp[-2]);
 226                                 file = getcpy(expanddir(cp));
 227                                 continue;
 228                         case FORMSW:
 229                                 if (!(form = *argp++) || *form == '-')
 230                                         adios(EX_USAGE, NULL, "missing argument to %s",
 231                                                         argp[-2]);
 232                                 continue;
 233
 234                         case FILTSW:
 235                                 if (!(cp = *argp++) || *cp == '-')
 236                                         adios(EX_USAGE, NULL, "missing argument to %s",
 237                                                         argp[-2]);
 238                                 filter = getcpy(etcpath(cp));
 239                                 continue;
 240                         case NFILTSW:
 241                                 filter = NULL;
 242                                 continue;
 243
 244                         case MIMESW:
 245                                 mime++;
 246                                 continue;
 247                         case NMIMESW:
 248                                 mime = 0;
 249                                 continue;
 250
 251                         case QURYSW:
 252                                 querysw++;
 253                                 continue;
 254                         case NQURYSW:
 255                                 querysw = 0;
 256                                 continue;
 257
 258                         }
 259                 }
 260                 if (*cp == '+' || *cp == '@') {
 261                         if (folder)
 262                                 adios(EX_USAGE, NULL, "only one folder at a time!");
 263                         else
 264                                 folder = getcpy(expandfol(cp));
 265                 } else {
 266                         if (msg)
 267                                 adios(EX_USAGE, NULL, "only one message at a time!");
 268                         else
 269                                 msg = cp;
 270                 }
 271         }
 272
 273         if (ccto == -1)
 274                 ccto = groupreply;
 275         if (cccc == -1)
 276                 cccc = groupreply;
 277         if (ccme == -1)
 278                 ccme = groupreply;
 279
 280         cwd = getcpy(pwd());
 281
 282         if (file && (msg || folder))
 283                 adios(EX_USAGE, NULL, "can't mix files and folders/msgs");
 284
 285         strncpy(drft, buildsw ? toabsdir("reply") : m_draft(seq_beyond),
 286                         sizeof(drft));
 287         /*
 288         ** FIXME: (concerning MHE support (buildsw) only)
 289         ** There's no check if the draft already exists. mmh has removed
 290         ** this case by having the draft folder. I won't add code only to
 291         ** handle this legacy issue for MHE. -- meillo@marmaro.de 2012-05
 292         */
 293
 294         if (file) {
 295                 /*
 296                 ** We are replying to a file.
 297                 */
 298                 anot = 0;  /* we don't want to annotate a file */
 299         } else {
 300                 /*
 301                 ** We are replying to a message.
 302                 */
 303                 if (!msg)
 304                         msg = seq_cur;
 305                 if (!folder)
 306                         folder = getcurfol();
 307                 maildir = toabsdir(folder);
 308
 309                 if (chdir(maildir) == NOTOK)
 310                         adios(EX_OSERR, maildir, "unable to change directory to");
 311
 312                 /* read folder and create message structure */
 313                 if (!(mp = folder_read(folder)))
 314                         adios(EX_IOERR, NULL, "unable to read folder %s", folder);
 315
 316                 /* check for empty folder */
 317                 if (mp->nummsg == 0)
 318                         adios(EX_DATAERR, NULL, "no messages in %s", folder);
 319
 320                 /* parse the message range/sequence/name and set SELECTED */
 321                 if (!m_convert(mp, msg))
 322                         exit(EX_SOFTWARE);
 323                 seq_setprev(mp);  /* set the previous-sequence */
 324
 325                 if (mp->numsel > 1)
 326                         adios(EX_USAGE, NULL, "only one message at a time!");
 327
 328                 context_replace(curfolder, folder); /* update current folder */
 329                 seq_setcur(mp, mp->lowsel);  /* update current message  */
 330                 seq_save(mp);  /* synchronize sequences   */
 331                 context_save();  /* save the context file   */
 332         }
 333
 334         msg = file ? file : getcpy(m_name(mp->lowsel));
 335
 336         if ((in = fopen(msg, "r")) == NULL)
 337                 adios(EX_IOERR, msg, "unable to open");
 338
 339         /* find form (components) file */
 340         if (!form) {
 341                 if (groupreply)
 342                         form = etcpath(replgroupcomps);
 343                 else
 344                         form = etcpath(replcomps);
 345         }
 346
 347         replout(in, drft, mp, mime, form, filter);
 348         fclose(in);
 349
 350         if (buildsw)
 351                 exit(EX_OK);
 352         what_now(ed, NOUSE, drft, msg, 0, mp, anot ? "Replied" : NULL, cwd);
 353         return EX_OSERR;
 354 }
 355
 356 static void
 357 docc(char *cp, int ccflag)
 358 {
 359         switch (smatch(cp, ccswitches)) {
 360         case AMBIGSW:
 361                 ambigsw(cp, ccswitches);
 362                 exit(EX_USAGE);
 363         case UNKWNSW:
 364                 adios(EX_USAGE, NULL, "-%scc %s unknown", ccflag ? "" : "no", cp);
 365
 366         case CTOSW:
 367                 ccto = ccflag;
 368                 break;
 369
 370         case CCCSW:
 371                 cccc = ccflag;
 372                 break;
 373
 374         case CMESW:
 375                 ccme = ccflag;
 376                 break;
 377
 378         case CALSW:
 379                 ccto = cccc = ccme = ccflag;
 380                 break;
 381         }
 382 }
 383
 384
 385
 386
 387 static void
 388 replout(FILE *inb, char *drft, struct msgs *mp,
 389         int mime, char *form, char *filter)
 390 {
 391         int state, i;
 392         struct comp *cptr;
 393         char *tmpbuf;
 394         char **nxtbuf;
 395         char **ap;
 396         struct comp **savecomp;
 397         int char_read = 0, format_len, mask;
 398         char name[NAMESZ], *scanl;
 399         unsigned char *cp;
 400         FILE *out;
 401
 402         mask = umask(~m_gmprot());
 403         if ((out = fopen(drft, "w")) == NULL)
 404                 adios(EX_CANTCREAT, drft, "unable to create");
 405
 406         umask(mask);
 407
 408         /* get new format string */
 409         cp = new_fs(form, NULL);
 410         format_len = strlen(cp);
 411
 412         /* compile format string */
 413         ncomps = fmt_compile(cp, &fmt) + 1;
 414
 415         nxtbuf = compbuffers = (char **)
 416                         mh_xcalloc((size_t) ncomps, sizeof(char *));
 417         savecomp = used_buf = (struct comp **)
 418                         mh_xcalloc((size_t) (ncomps+1), sizeof(struct comp *));
 419         savecomp += ncomps + 1;
 420         *--savecomp = NULL;  /* point at zero'd end minus 1 */
 421
 422         for (i = ncomps; i--; )
 423                 *nxtbuf++ = mh_xcalloc(SBUFSIZ, sizeof(char));
 424
 425         nxtbuf = compbuffers;  /* point at start */
 426         tmpbuf = *nxtbuf++;
 427
 428         for (ap = addrcomps; *ap; ap++) {
 429                 FINDCOMP(cptr, *ap);
 430                 if (cptr)
 431                         cptr->c_type |= CT_ADDR;
 432         }
 433
 434         /*
 435         ** ignore any components killed by command line switches
 436         */
 437         if (!ccto) {
 438                 FINDCOMP(cptr, "to");
 439                 if (cptr)
 440                         cptr->c_name = "";
 441         }
 442         if (!cccc) {
 443                 FINDCOMP(cptr, "cc");
 444                 if (cptr)
 445                         cptr->c_name = "";
 446         }
 447         if ((cp = getenv("USER"))) {
 448                 FINDCOMP(cptr, "user");
 449                 if (cptr)
 450                         cptr->c_text = getcpy(cp);
 451         }
 452         if (!ccme)
 453                 ismymbox(NULL);
 454
 455         /*
 456         ** pick any interesting stuff out of msg "inb"
 457         */
 458         for (state = FLD;;) {
 459                 state = m_getfld(state, name, tmpbuf, SBUFSIZ, inb);
 460                 switch (state) {
 461                 case FLD:
 462                 case FLDPLUS:
 463                         /*
 464                         ** if we're interested in this component, save
 465                         ** a pointer to the component text, then start
 466                         ** using our next free buffer as the component
 467                         ** temp buffer (buffer switching saves an extra
 468                         ** copy of the component text).
 469                         */
 470                         if ((cptr = wantcomp[CHASH(name)]))
 471                                 do {
 472                                         if (!mh_strcasecmp(name, cptr->c_name)) {
 473                                                 char_read += msg_count;
 474                                                 if (! cptr->c_text) {
 475                                                         i = strlen(cptr->c_text = tmpbuf) - 1;
 476                                                         if (tmpbuf[i] == '\n')
 477                                                                 tmpbuf[i] = '\0';
 478                                                         *--savecomp = cptr;
 479                                                         tmpbuf = *nxtbuf++;
 480                                                 } else {
 481                                                         i = strlen(cp = cptr->c_text) - 1;
 482                                                         if (cp[i] == '\n') {
 483                                                                 if (cptr->c_type & CT_ADDR) {
 484                                                                         cp[i] = '\0';
 485                                                                         cp = add(",\n\t", cp);
 486                                                                 } else {
 487                                                                         cp = add("\t", cp);
 488                                                                 }
 489                                                         }
 490                                                         cptr->c_text = add(tmpbuf, cp);
 491                                                 }
 492                                                 while (state == FLDPLUS) {
 493                                                         state = m_getfld(state, name, tmpbuf,
 494                                                                                           SBUFSIZ, inb);
 495                                                         cptr->c_text = add(tmpbuf, cptr->c_text);
 496                                                         char_read += msg_count;
 497                                                 }
 498                                                 break;
 499                                         }
 500                                 } while ((cptr = cptr->c_next));
 501
 502                         while (state == FLDPLUS)
 503                                 state = m_getfld(state, name, tmpbuf,
 504                                                 SBUFSIZ, inb);
 505                         break;
 506
 507                 case LENERR:
 508                 case FMTERR:
 509                 case BODY:
 510                 case FILEEOF:
 511                         goto finished;
 512
 513                 default:
 514                         adios(EX_SOFTWARE, NULL, "m_getfld() returned %d", state);
 515                 }
 516         }
 517
 518         /*
 519         ** format and output the header lines.
 520         */
 521 finished:
 522
 523         /*
 524         ** if there's a "Subject" component, strip any "Re:"s off it
 525         */
 526         FINDCOMP(cptr, "subject")
 527         if (cptr && (cp = cptr->c_text)) {
 528                 char *sp = cp;
 529
 530                 for (;;) {
 531                         while (isspace(*cp))
 532                                 cp++;
 533                         if(uprf(cp, "re:"))
 534                                 cp += 3;
 535                         else
 536                                 break;
 537                         sp = cp;
 538                 }
 539                 if (sp != cptr->c_text) {
 540                         cp = cptr->c_text;
 541                         cptr->c_text = getcpy(sp);
 542                         free(cp);
 543                 }
 544         }
 545         i = format_len + char_read + 256;
 546         scanl = mh_xcalloc((size_t) i + 2, sizeof(char));
 547         dat[0] = 0;
 548         dat[1] = 0;
 549         dat[2] = 0;
 550         dat[3] = OUTPUTLINELEN;
 551         dat[4] = 0;
 552         fmt_scan(fmt, scanl, i, dat);
 553         fputs(scanl, out);
 554         if (badaddrs) {
 555                 fputs("\nrepl: bad addresses:\n", out);
 556                 fputs( badaddrs, out);
 557         }
 558
 559         /* Check if we should filter the message */
 560         if (filter) {
 561                 fflush(out);
 562                 if (ferror(out))
 563                         adios(EX_IOERR, drft, "error writing");
 564
 565                 replfilter(inb, out, filter);
 566         }
 567
 568         fflush(out);
 569         if (ferror(out))
 570                 adios(EX_IOERR, drft, "error writing");
 571         fclose(out);
 572
 573         if (mime && mp) {
 574                 /* add an attachment header */
 575                 char buffer[BUFSIZ];
 576
 577                 snprintf(buffer, sizeof buffer, "+%s %s",
 578                                 mp->foldpath, m_name(mp->lowsel));
 579                 if (execprogl("anno", "anno", "-append", "-nodate",
 580                                 drft, "-comp", attach_hdr, "-text", buffer,
 581                                 (char *)NULL) != 0) {
 582                         advise(NULL, "unable to add attachment header");
 583                 }
 584         }
 585
 586         /* return dynamically allocated buffers */
 587         free(scanl);
 588         for (nxtbuf = compbuffers, i = ncomps; (cptr = *savecomp++);
 589                         nxtbuf++, i--)
 590                 free(cptr->c_text);  /* if not nxtbuf, nxtbuf already freed */
 591         while ( i-- > 0)
 592                 free(*nxtbuf++);  /* free unused nxtbufs */
 593         free((char *) compbuffers);
 594         free((char *) used_buf);
 595 }
 596
 597 static char *buf;  /* our current working buffer */
 598 static char *bufend;  /* end of working buffer */
 599 static char *last_dst;  /* buf ptr at end of last call */
 600 static unsigned int bufsiz=0;  /* current size of buf */
 601
 602 #define BUFINCR 512  /* how much to expand buf when if fills */
 603
 604 #define CPY(s) { cp = (s); while ((*dst++ = *cp++)) ; --dst; }
 605
 606 /*
 607 ** check if there's enough room in buf for str.
 608 ** add more mem if needed
 609 */
 610 #define CHECKMEM(str) \
 611         if ((len = strlen(str)) >= bufend - dst) {\
 612                 int i = dst - buf;\
 613                 int n = last_dst - buf;\
 614                 bufsiz += ((dst + len - bufend) / BUFINCR + 1) * BUFINCR;\
 615                 buf = mh_xrealloc(buf, bufsiz);\
 616                 dst = buf + i;\
 617                 last_dst = buf + n;\
 618                 bufend = buf + bufsiz;\
 619         }
 620
 621
 622 /*
 623 ** fmt_scan will call this routine if the user includes the function
 624 ** "(formataddr {component})" in a format string.  "orig" is the
 625 ** original contents of the string register.  "str" is the address
 626 ** string to be formatted and concatenated onto orig.  This routine
 627 ** returns a pointer to the concatenated address string.
 628 **
 629 ** We try to not do a lot of malloc/copy/free's (which is why we
 630 ** don't call "getcpy") but still place no upper limit on the
 631 ** length of the result string.
 632 **
 633 ** This routine is an override for the equally named one in sbr/fmt_addr.c.
 634 ** Don't delete it!
 635 */
 636 char *
 637 formataddr(char *orig, char *str)
 638 {
 639         int len;
 640         char baddr[BUFSIZ], error[BUFSIZ];
 641         int isgroup;
 642         char *dst;
 643         char *cp;
 644         char *sp;
 645         struct mailname *mp = NULL;
 646
 647         /* if we don't have a buffer yet, get one */
 648         if (bufsiz == 0) {
 649                 buf = mh_xcalloc(BUFINCR, sizeof(char));
 650                 last_dst = buf;  /* XXX */
 651                 bufsiz = BUFINCR - 6;  /* leave some slop */
 652                 bufend = buf + bufsiz;
 653         }
 654         /*
 655         ** If "orig" points to our buffer we can just pick up where we
 656         ** left off.  Otherwise we have to copy orig into our buffer.
 657         */
 658         if (orig == buf)
 659                 dst = last_dst;
 660         else if (!orig || !*orig) {
 661                 dst = buf;
 662                 *dst = '\0';
 663         } else {
 664                 dst = last_dst;  /* XXX */
 665                 CHECKMEM(orig);
 666                 CPY(orig);
 667         }
 668
 669         /* concatenate all the new addresses onto 'buf' */
 670         for (isgroup = 0; (cp = getname(str)); ) {
 671                 if ((mp = getm(cp, dfhost, dftype, AD_NAME, error)) == NULL) {
 672                         snprintf(baddr, sizeof(baddr), "\t%s -- %s\n",
 673                                         cp, error);
 674                         badaddrs = add(baddr, badaddrs);
 675                         continue;
 676                 }
 677                 if (isgroup && (mp->m_gname || !mp->m_ingrp)) {
 678                         *dst++ = ';';
 679                         isgroup = 0;
 680                 }
 681                 if (insert(mp)) {
 682                         /* if we get here we're going to add an address */
 683                         if (dst != buf) {
 684                                 *dst++ = ',';
 685                                 *dst++ = ' ';
 686                         }
 687                         if (mp->m_gname) {
 688                                 CHECKMEM(mp->m_gname);
 689                                 CPY(mp->m_gname);
 690                                 isgroup++;
 691                         }
 692                         sp = adrformat(mp);
 693                         CHECKMEM(sp);
 694                         CPY(sp);
 695                 }
 696         }
 697
 698         if (isgroup)
 699                 *dst++ = ';';
 700
 701         *dst = '\0';
 702         last_dst = dst;
 703         return (buf);
 704 }
 705
 706
 707 static int
 708 insert(struct mailname *np)
 709 {
 710         char buffer[BUFSIZ];
 711         struct mailname *mp;
 712
 713         if (np->m_mbox == NULL)
 714                 return 0;
 715
 716         for (mp = &mq; mp->m_next; mp = mp->m_next) {
 717                 if (!mh_strcasecmp(np->m_host, mp->m_next->m_host) &&
 718                                 !mh_strcasecmp(np->m_mbox, mp->m_next->m_mbox))
 719                         return 0;
 720         }
 721         if (!ccme && ismymbox(np))
 722                 return 0;
 723
 724         if (querysw) {
 725                 snprintf(buffer, sizeof(buffer), "Reply to %s? ",
 726                                 adrformat(np));
 727                 if (!gans(buffer, anoyes))
 728                         return 0;
 729         }
 730         mp->m_next = np;
 731         return 1;
 732 }
 733
 734
 735 /*
 736 ** Call mhl
 737 **
 738 ** This function expects that argument out has been fflushed by the caller.
 739 */
 740 static void
 741 replfilter(FILE *in, FILE *out, char *filter)
 742 {
 743         int pid, pid_show, n;
 744         int mailpipe[2];
 745         char *errstr;
 746
 747         if (filter == NULL)
 748                 return;
 749
 750         if (access(filter, R_OK) == NOTOK)
 751                 adios(EX_IOERR, filter, "unable to read");
 752
 753         rewind(in);
 754         lseek(fileno(in), (off_t) 0, SEEK_SET);
 755
 756         if (pipe(mailpipe) == -1) {
 757                 adios(EX_OSERR, "pipe", "can't create pipe");
 758         }
 759
 760         switch (pid_show = fork()) {
 761         case NOTOK:
 762                 adios(EX_OSERR, "fork", "unable to");
 763
 764         case OK:
 765                 dup2(fileno(in), fileno(stdin));
 766                 dup2(mailpipe[1], fileno(stdout));
 767                 for (n=3; n<OPEN_MAX; n++) {
 768                         close(n);
 769                 }
 770
 771                 execlp("show", "show", "-file", "-", NULL);
 772
 773                 adios(EX_OSERR, "exec", "unable to");
 774         }
 775
 776         switch (pid = fork()) {
 777         case NOTOK:
 778                 adios(EX_OSERR, "fork", "unable to");
 779
 780         case OK:
 781                 dup2(mailpipe[0], fileno(stdin));
 782                 dup2(fileno(out), fileno(stdout));
 783                 for (n=3; n<OPEN_MAX; n++) {
 784                         close(n);
 785                 }
 786
 787                 execlp("mhl", "mhl", "-form", filter, NULL);
 788                 errstr = strerror(errno);
 789                 write(2, "unable to exec mhl: ", 20);
 790                 write(2, errstr, strlen(errstr));
 791                 write(2, "\n", 1);
 792                 _exit(EX_OSERR);
 793
 794         default:
 795                 if (pidXwait(-1, "show | mhl"))
 796                         exit(EX_SOFTWARE);
 797                 fseek(out, 0L, SEEK_END);
 798                 break;
 799         }
 800
 801         close(mailpipe[0]);
 802         close(mailpipe[1]);
 803 }