cmd1.c

   1 /*@ S-nail - a mail user agent derived from Berkeley Mail.
   2  *@ User commands.
   3  *
   4  * Copyright (c) 2000-2004 Gunnar Ritter, Freiburg i. Br., Germany.
   5  * Copyright (c) 2012 - 2014 Steffen (Daode) Nurpmeso <sdaoden@users.sf.net>.
   6  */
   7 /*
   8  * Copyright (c) 1980, 1993
   9  * The Regents of the University of California.  All rights reserved.
  10  *
  11  * Redistribution and use in source and binary forms, with or without
  12  * modification, are permitted provided that the following conditions
  13  * are met:
  14  * 1. Redistributions of source code must retain the above copyright
  15  *    notice, this list of conditions and the following disclaimer.
  16  * 2. Redistributions in binary form must reproduce the above copyright
  17  *    notice, this list of conditions and the following disclaimer in the
  18  *    documentation and/or other materials provided with the distribution.
  19  * 3. All advertising materials mentioning features or use of this software
  20  *    must display the following acknowledgement:
  21  *    This product includes software developed by the University of
  22  *    California, Berkeley and its contributors.
  23  * 4. Neither the name of the University nor the names of its contributors
  24  *    may be used to endorse or promote products derived from this software
  25  *    without specific prior written permission.
  26  *
  27  * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
  28  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
  29  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
  30  * ARE DISCLAIMED.  IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
  31  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
  32  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
  33  * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
  34  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
  35  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
  36  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
  37  * SUCH DAMAGE.
  38  */
  39
  40 #ifndef HAVE_AMALGAMATION
  41 # include "nail.h"
  42 #endif
  43
  44 static int        _screen;
  45 static sigjmp_buf _cmd1_pipestop;
  46 static sigjmp_buf _cmd1_pipejmp;
  47
  48 static void    _cmd1_onpipe(int signo);
  49 static void    _cmd1_brokpipe(int signo);
  50
  51 /* Prepare and print "[Message: xy]:" intro */
  52 static void    _show_msg_overview(FILE *obuf, struct message *mp, int msg_no);
  53
  54 /* ... And place the extracted date in `date' */
  55 static void    _parse_from_(struct message *mp, char date[FROM_DATEBUF]);
  56
  57 /* Print out the header of a specific message
  58  * __hprf: handle *headline*
  59  * __subject: Subject:, but return NULL if threaded and Subject: yet seen
  60  * __putindent: print out the indenting in threaded display */
  61 static void    _print_head(size_t yetprinted, size_t msgno, FILE *f,
  62                   bool_t threaded);
  63 static void    __hprf(size_t yetprinted, char const *fmt, size_t msgno,
  64                   FILE *f, bool_t threaded, char const *attrlist);
  65 static char *  __subject(struct message *mp, bool_t threaded,
  66                   size_t yetprinted);
  67 static char *  __subject_trim(char *s);
  68 static int     __putindent(FILE *fp, struct message *mp, int maxwidth);
  69
  70 static int     _dispc(struct message *mp, char const *a);
  71 static int     _scroll1(char *arg, int onlynew);
  72
  73 /* Show the requested messages */
  74 static int     _type1(int *msgvec, bool_t doign, bool_t dopage, bool_t dopipe,
  75                   bool_t dodecode, char *cmd, off_t *tstats);
  76
  77 /* Pipe the requested messages */
  78 static int     _pipe1(char *str, int doign);
  79
  80 static void
  81 _cmd1_onpipe(int signo)
  82 {
  83    NYD_X; /* Signal handler */
  84    UNUSED(signo);
  85    siglongjmp(_cmd1_pipejmp, 1);
  86 }
  87
  88 static void
  89 _cmd1_brokpipe(int signo)
  90 {
  91    NYD_X; /* Signal handler */
  92    UNUSED(signo);
  93    siglongjmp(_cmd1_pipestop, 1);
  94 }
  95
  96 static void
  97 _show_msg_overview(FILE *obuf, struct message *mp, int msg_no)
  98 {
  99    char const *cpre = "", *csuf = "";
 100    NYD_ENTER;
 101
 102 #ifdef HAVE_COLOUR
 103    if (colour_table != NULL) {
 104       struct str const *sp;
 105
 106       if ((sp = colour_get(COLOURSPEC_MSGINFO)) != NULL)
 107          cpre = sp->s;
 108       csuf = colour_get(COLOURSPEC_RESET)->s;
 109    }
 110 #endif
 111    fprintf(obuf, _("%s[-- Message %2d -- %lu lines, %lu bytes --]:%s\n"),
 112       cpre, msg_no, (ul_it)mp->m_lines, (ul_it)mp->m_size, csuf);
 113    NYD_LEAVE;
 114 }
 115
 116 static void
 117 _parse_from_(struct message *mp, char date[FROM_DATEBUF]) /* TODO line pool */
 118 {
 119    FILE *ibuf;
 120    int hlen;
 121    char *hline = NULL;
 122    size_t hsize = 0;
 123    NYD_ENTER;
 124
 125    if ((ibuf = setinput(&mb, mp, NEED_HEADER)) != NULL &&
 126          (hlen = readline_restart(ibuf, &hline, &hsize, 0)) > 0)
 127       extract_date_from_from_(hline, hlen, date);
 128    if (hline != NULL)
 129       free(hline);
 130    NYD_LEAVE;
 131 }
 132
 133 static void
 134 _print_head(size_t yetprinted, size_t msgno, FILE *f, bool_t threaded)
 135 {
 136    enum {attrlen = 13};
 137    char attrlist[attrlen +1], *cp;
 138    char const *fmt;
 139    NYD_ENTER;
 140
 141    if ((cp = ok_vlook(attrlist)) != NULL) {
 142       if (strlen(cp) == attrlen) {
 143          memcpy(attrlist, cp, attrlen +1);
 144          goto jattrok;
 145       }
 146       fprintf(stderr, _(
 147          "The value of *attrlist* is not of the correct length\n"));
 148    }
 149    if (ok_blook(bsdcompat) || ok_blook(bsdflags) ||
 150          getenv("SYSV3") != NULL) {
 151       char const bsdattr[attrlen +1] = "NU  *HMFAT+-$";
 152       memcpy(attrlist, bsdattr, sizeof bsdattr);
 153    } else {
 154       char const pattr[attrlen +1] = "NUROSPMFAT+-$";
 155       memcpy(attrlist, pattr, sizeof pattr);
 156    }
 157 jattrok:
 158    if ((fmt = ok_vlook(headline)) == NULL) {
 159       fmt = ((ok_blook(bsdcompat) || ok_blook(bsdheadline))
 160             ? "%>%a%m %-20f  %16d %3l/%-5o %i%-S"
 161             : "%>%a%m %-18f %16d %4l/%-5o %i%-s");
 162    }
 163
 164    __hprf(yetprinted, fmt, msgno, f, threaded, attrlist);
 165    NYD_LEAVE;
 166 }
 167
 168 static void
 169 __hprf(size_t yetprinted, char const *fmt, size_t msgno, FILE *f,
 170    bool_t threaded, char const *attrlist)
 171 {
 172    char datebuf[FROM_DATEBUF], *cp, *subjline;
 173    char const *datefmt, *date, *name, *fp;
 174    int B, c, i, n, s, wleft, subjlen, isto = 0, isaddr = 0;
 175    struct message *mp;
 176    time_t datet;
 177    NYD_ENTER;
 178
 179    mp = message + msgno - 1;
 180    datet = mp->m_time;
 181    date = NULL;
 182
 183    datefmt = ok_vlook(datefield);
 184 jredo:
 185    if (datefmt != NULL) {
 186       fp = hfield1("date", mp);/* TODO use m_date field! */
 187       if (fp == NULL) {
 188          datefmt = NULL;
 189          goto jredo;
 190       }
 191       datet = rfctime(fp);
 192       date = fakedate(datet);
 193       fp = ok_vlook(datefield_markout_older);
 194       i = (*datefmt != '\0');
 195       if (fp != NULL)
 196          i |= (*fp != '\0') ? 2 | 4 : 2; /* XXX no magics */
 197
 198       /* May we strftime(3)? */
 199       if (i & (1 | 4))
 200          memcpy(&time_current.tc_local, localtime(&datet),
 201             sizeof time_current.tc_local);
 202
 203       if ((i & 2) && (datet > time_current.tc_time + DATE_SECSDAY ||
 204 #define _6M ((DATE_DAYSYEAR / 2) * DATE_SECSDAY)
 205             (datet + _6M < time_current.tc_time))) {
 206 #undef _6M
 207          if ((datefmt = (i & 4) ? fp : NULL) == NULL) {
 208             memset(datebuf, ' ', FROM_DATEBUF); /* xxx ur */
 209             memcpy(datebuf + 4, date + 4, 7);
 210             datebuf[4 + 7] = ' ';
 211             memcpy(datebuf + 4 + 7 + 1, date + 20, 4);
 212             datebuf[4 + 7 + 1 + 4] = '\0';
 213             date = datebuf;
 214          }
 215       } else if ((i & 1) == 0)
 216          datefmt = NULL;
 217    } else if (datet == (time_t)0 && !(mp->m_flag & MNOFROM)) {
 218       /* TODO eliminate this path, query the FROM_ date in setptr(),
 219        * TODO all other codepaths do so by themselves ALREADY ?????
 220        * TODO assert(mp->m_time != 0);, then
 221        * TODO ALSO changes behaviour of datefield_markout_older */
 222       _parse_from_(mp, datebuf);
 223       date = datebuf;
 224    } else
 225       date = fakedate(datet);
 226
 227    isaddr = 1;
 228    name = name1(mp, 0);
 229    if (name != NULL && ok_blook(showto) && is_myname(skin(name))) {
 230       if ((cp = hfield1("to", mp)) != NULL) {
 231          name = cp;
 232          isto = 1;
 233       }
 234    }
 235    if (name == NULL) {
 236       name = "";
 237       isaddr = 0;
 238    }
 239    if (isaddr)
 240       name = ok_blook(showname) ? realname(name) : prstr(skin(name));
 241
 242    subjline = NULL;
 243
 244    /* Detect the width of the non-format characters in *headline*;
 245     * like that we can simply use putc() in the next loop, since we have
 246     * already calculated their column widths (TODO it's sick) */
 247    wleft = subjlen = scrnwidth;
 248
 249    for (fp = fmt; *fp != '\0'; ++fp) {
 250       if (*fp == '%') {
 251          if (*++fp == '-')
 252             ++fp;
 253          else if (*fp == '+')
 254             ++fp;
 255          if (digitchar(*fp)) {
 256             n = 0;
 257             do
 258                n = 10*n + *fp - '0';
 259             while (++fp, digitchar(*fp));
 260             subjlen -= n;
 261          }
 262
 263          if (*fp == '\0')
 264             break;
 265       } else {
 266 #ifdef HAVE_WCWIDTH
 267          if (mb_cur_max > 1) {
 268             wchar_t  wc;
 269             if ((s = mbtowc(&wc, fp, mb_cur_max)) == -1)
 270                n = s = 1;
 271             else if ((n = wcwidth(wc)) == -1)
 272                n = 1;
 273          } else
 274 #endif
 275             n = s = 1;
 276          subjlen -= n;
 277          wleft -= n;
 278          while (--s > 0)
 279             ++fp;
 280       }
 281    }
 282
 283    /* Walk *headline*, producing output TODO not (really) MB safe */
 284    for (fp = fmt; *fp != '\0'; ++fp) {
 285       if ((c = *fp & 0xFF) != '%')
 286          putc(c, f);
 287       else {
 288          B = 0;
 289          n = 0;
 290          s = 1;
 291          if (*++fp == '-') {
 292             s = -1;
 293             ++fp;
 294          } else if (*fp == '+')
 295             ++fp;
 296          if (digitchar(*fp)) {
 297             do
 298                n = 10*n + *fp - '0';
 299             while (++fp, digitchar(*fp));
 300          }
 301          if (*fp == '\0')
 302             break;
 303
 304          n *= s;
 305          switch ((c = *fp & 0xFF)) {
 306          case '%':
 307             goto jputc;
 308          case '>':
 309          case '<':
 310             if (dot != mp)
 311                c = ' ';
 312             goto jputc;
 313          case '$':
 314 #ifdef HAVE_SPAM
 315             if (n == 0)
 316                n = 4;
 317             if (UICMP(32, ABS(n), >, wleft))
 318                n = (n < 0) ? -wleft : wleft;
 319             {  char buf[16];
 320                snprintf(buf, sizeof buf, "%u.%u",
 321                   (mp->m_spamscore >> 8), (mp->m_spamscore & 0xFF));
 322                n = fprintf(f, "%*s", n, buf);
 323                wleft = (n >= 0) ? wleft - n : 0;
 324             }
 325 #else
 326             c = '?';
 327             goto jputc;
 328 #endif
 329          case 'a':
 330             c = _dispc(mp, attrlist);
 331 jputc:
 332             if (UICMP(32, ABS(n), >, wleft))
 333                n = (n < 0) ? -wleft : wleft;
 334             n = fprintf(f, "%*c", n, c);
 335             wleft = (n >= 0) ? wleft - n : 0;
 336             break;
 337          case 'd':
 338             if (datefmt != NULL) {
 339                i = strftime(datebuf, sizeof datebuf, datefmt,
 340                      &time_current.tc_local);
 341                if (i != 0)
 342                   date = datebuf;
 343                else
 344                   fprintf(stderr, _(
 345                      "Ignored date format, it excesses the target buffer "
 346                      "(%lu bytes)\n"), (ul_it)sizeof datebuf);
 347                datefmt = NULL;
 348             }
 349             if (n == 0)
 350                n = 16;
 351             if (UICMP(32, ABS(n), >, wleft))
 352                n = (n < 0) ? -wleft : wleft;
 353             n = fprintf(f, "%*.*s", n, n, date);
 354             wleft = (n >= 0) ? wleft - n : 0;
 355             break;
 356          case 'e':
 357             if (n == 0)
 358                n = 2;
 359             if (UICMP(32, ABS(n), >, wleft))
 360                n = (n < 0) ? -wleft : wleft;
 361             n = fprintf(f, "%*u", n, (threaded == 1 ? mp->m_level : 0));
 362             wleft = (n >= 0) ? wleft - n : 0;
 363             break;
 364          case 'f':
 365             if (n == 0) {
 366                n = 18;
 367                if (s < 0)
 368                   n = -n;
 369             }
 370             i = ABS(n);
 371             if (i > wleft) {
 372                i = wleft;
 373                n = (n < 0) ? -wleft : wleft;
 374             }
 375             if (isto) /* XXX tr()! */
 376                i -= 3;
 377             n = fprintf(f, "%s%s", (isto ? "To " : ""),
 378                   colalign(name, i, n, &wleft));
 379             if (n < 0)
 380                wleft = 0;
 381             else if (isto)
 382                wleft -= 3;
 383             break;
 384          case 'i':
 385             if (threaded) {
 386                n = __putindent(f, mp, MIN(wleft, scrnwidth - 60));
 387                wleft = (n >= 0) ? wleft - n : 0;
 388             }
 389             break;
 390          case 'l':
 391             if (n == 0)
 392                n = 4;
 393             if (UICMP(32, ABS(n), >, wleft))
 394                n = (n < 0) ? -wleft : wleft;
 395             if (mp->m_xlines) {
 396                n = fprintf(f, "%*ld", n, mp->m_xlines);
 397                wleft = (n >= 0) ? wleft - n : 0;
 398             } else {
 399                n = ABS(n);
 400                wleft -= n;
 401                while (n-- != 0)
 402                   putc(' ', f);
 403             }
 404             break;
 405          case 'm':
 406             if (n == 0) {
 407                n = 3;
 408                if (threaded)
 409                   for (i = msgCount; i > 999; i /= 10)
 410                      ++n;
 411             }
 412             if (UICMP(32, ABS(n), >, wleft))
 413                n = (n < 0) ? -wleft : wleft;
 414             n = fprintf(f, "%*lu", n, (ul_it)msgno);
 415             wleft = (n >= 0) ? wleft - n : 0;
 416             break;
 417          case 'o':
 418             if (n == 0)
 419                n = -5;
 420             if (UICMP(32, ABS(n), >, wleft))
 421                n = (n < 0) ? -wleft : wleft;
 422             n = fprintf(f, "%*lu", n, (long)mp->m_xsize);
 423             wleft = (n >= 0) ? wleft - n : 0;
 424             break;
 425          case 'S':
 426             B = 1;
 427             /*FALLTHRU*/
 428          case 's':
 429             if (n == 0)
 430                n = subjlen - 2;
 431             if (n > 0 && s < 0)
 432                n = -n;
 433             if (subjlen > wleft)
 434                subjlen = wleft;
 435             if (UICMP(32, ABS(n), >, subjlen))
 436                n = (n < 0) ? -subjlen : subjlen;
 437             if (B)
 438                n -= (n < 0) ? -2 : 2;
 439             if (n == 0)
 440                break;
 441             if (subjline == NULL)
 442                subjline = __subject(mp, threaded, yetprinted);
 443             if (subjline == (char*)-1) {
 444                n = fprintf(f, "%*s", n, "");
 445                wleft = (n >= 0) ? wleft - n : 0;
 446             } else {
 447                n = fprintf(f, (B ? "\"%s\"" : "%s"),
 448                      colalign(subjline, ABS(n), n, &wleft));
 449                if (n < 0)
 450                   wleft = 0;
 451             }
 452             break;
 453          case 't':
 454             if (n == 0) {
 455                n = 3;
 456                if (threaded)
 457                   for (i = msgCount; i > 999; i /= 10)
 458                      ++n;
 459             }
 460             if (UICMP(32, ABS(n), >, wleft))
 461                n = (n < 0) ? -wleft : wleft;
 462             n = fprintf(f, "%*lu", n,
 463                   (threaded ? (ul_it)mp->m_threadpos : (ul_it)msgno));
 464             wleft = (n >= 0) ? wleft - n : 0;
 465             break;
 466          case 'U':
 467 #ifdef HAVE_IMAP
 468             if (n == 0)
 469                n = 9;
 470             if (UICMP(32, ABS(n), >, wleft))
 471                n = (n < 0) ? -wleft : wleft;
 472             n = fprintf(f, "%*lu", n, mp->m_uid);
 473             wleft = (n >= 0) ? wleft - n : 0;
 474             break;
 475 #else
 476             c = '?';
 477             goto jputc;
 478 #endif
 479          }
 480
 481          if (wleft <= 0)
 482             break;
 483       }
 484    }
 485    putc('\n', f);
 486
 487    if (subjline != NULL && subjline != (char*)-1)
 488       free(subjline);
 489    NYD_LEAVE;
 490 }
 491
 492 static char *
 493 __subject_trim(char *s)
 494 {
 495    struct {
 496       ui8_t len;
 497       char  dat[7];
 498    } const *pp, ignored[] = { /* TODO make ignore list configurable */
 499       { 3, "re:" }, { 4, "fwd:" },
 500       { 3, "aw:" }, { 5, "antw:" },
 501       { 0, "" }
 502    };
 503    NYD_ENTER;
 504
 505 jouter:
 506    while (*s != '\0') {
 507       while (spacechar(*s))
 508          ++s;
 509       /* TODO While it is maybe ok not to MIME decode these (for purpose), we
 510        * TODO should skip =?..?= at the beginning? */
 511       for (pp = ignored; pp->len > 0; ++pp)
 512          if (is_asccaseprefix(pp->dat, s)) {
 513             s += pp->len;
 514             goto jouter;
 515          }
 516       break;
 517    }
 518    NYD_LEAVE;
 519    return s;
 520 }
 521
 522 static char *
 523 __subject(struct message *mp, bool_t threaded, size_t yetprinted)
 524 {
 525    /* XXX NOTE: because of efficiency reasons we simply ignore any encoded
 526     * XXX parts and use ASCII case-insensitive comparison */
 527    struct str in, out;
 528    struct message *xmp;
 529    char *rv = (char*)-1, *ms, *mso, *os;
 530    NYD_ENTER;
 531
 532    if ((ms = hfield1("subject", mp)) == NULL)
 533       goto jleave;
 534
 535    if (!threaded || mp->m_level == 0)
 536       goto jconv;
 537
 538    /* In a display thread - check wether this message uses the same
 539     * Subject: as it's parent or elder neighbour, suppress printing it if
 540     * this is the case.  To extend this a bit, ignore any leading Re: or
 541     * Fwd: plus follow-up WS.  Ignore invisible messages along the way */
 542    mso = __subject_trim(ms);
 543    for (xmp = mp; (xmp = prev_in_thread(xmp)) != NULL && yetprinted-- > 0;)
 544       if (visible(xmp) && (os = hfield1("subject", xmp)) != NULL &&
 545             !asccasecmp(mso, __subject_trim(os)))
 546          goto jleave;
 547 jconv:
 548    in.s = ms;
 549    in.l = strlen(ms);
 550    mime_fromhdr(&in, &out, TD_ICONV | TD_ISPR);
 551    rv = out.s;
 552 jleave:
 553    NYD_LEAVE;
 554    return rv;
 555 }
 556
 557 static int
 558 __putindent(FILE *fp, struct message *mp, int maxwidth)/* XXX no magic consts */
 559 {
 560    struct message *mq;
 561    int *us, indlvl, indw, i, important = MNEW | MFLAGGED;
 562    char *cs;
 563    NYD_ENTER;
 564
 565    if (mp->m_level == 0 || maxwidth == 0) {
 566       indw = 0;
 567       goto jleave;
 568    }
 569
 570    cs = ac_alloc(mp->m_level);
 571    us = ac_alloc(mp->m_level * sizeof *us);
 572
 573    i = mp->m_level - 1;
 574    if (mp->m_younger && UICMP(32, i + 1, ==, mp->m_younger->m_level)) {
 575       if (mp->m_parent && mp->m_parent->m_flag & important)
 576          us[i] = mp->m_flag & important ? 0x2523 : 0x2520;
 577       else
 578          us[i] = mp->m_flag & important ? 0x251D : 0x251C;
 579       cs[i] = '+';
 580    } else {
 581       if (mp->m_parent && mp->m_parent->m_flag & important)
 582          us[i] = mp->m_flag & important ? 0x2517 : 0x2516;
 583       else
 584          us[i] = mp->m_flag & important ? 0x2515 : 0x2514;
 585       cs[i] = '\\';
 586    }
 587
 588    mq = mp->m_parent;
 589    for (i = mp->m_level - 2; i >= 0; --i) {
 590       if (mq) {
 591          if (UICMP(32, i, >, mq->m_level - 1)) {
 592             us[i] = cs[i] = ' ';
 593             continue;
 594          }
 595          if (mq->m_younger) {
 596             if (mq->m_parent && (mq->m_parent->m_flag & important))
 597                us[i] = 0x2503;
 598             else
 599                us[i] = 0x2502;
 600             cs[i] = '|';
 601          } else
 602             us[i] = cs[i] = ' ';
 603          mq = mq->m_parent;
 604       } else
 605          us[i] = cs[i] = ' ';
 606    }
 607
 608    --maxwidth;
 609    for (indlvl = indw = 0; (ui8_t)indlvl < mp->m_level && indw < maxwidth;
 610          ++indlvl) {
 611       if (indw < maxwidth - 1)
 612          indw += (int)putuc(us[indlvl], cs[indlvl] & 0xFF, fp);
 613       else
 614          indw += (int)putuc(0x21B8, '^', fp);
 615    }
 616    indw += (/*putuc(0x261E, fp)*/putc('>', fp) != EOF);
 617
 618    ac_free(us);
 619    ac_free(cs);
 620 jleave:
 621    NYD_LEAVE;
 622    return indw;
 623 }
 624
 625 static int
 626 _dispc(struct message *mp, char const *a)
 627 {
 628    int i = ' ';
 629    NYD_ENTER;
 630
 631    if ((mp->m_flag & (MREAD | MNEW)) == MREAD)
 632       i = a[3];
 633    if ((mp->m_flag & (MREAD | MNEW)) == (MREAD | MNEW))
 634       i = a[2];
 635    if (mp->m_flag & MANSWERED)
 636       i = a[8];
 637    if (mp->m_flag & MDRAFTED)
 638       i = a[9];
 639    if ((mp->m_flag & (MREAD | MNEW)) == MNEW)
 640       i = a[0];
 641    if (!(mp->m_flag & (MREAD | MNEW)))
 642       i = a[1];
 643    if (mp->m_flag & MSPAM)
 644       i = a[12];
 645    if (mp->m_flag & MSAVED)
 646       i = a[4];
 647    if (mp->m_flag & MPRESERVE)
 648       i = a[5];
 649    if (mp->m_flag & (MBOX | MBOXED))
 650       i = a[6];
 651    if (mp->m_flag & MFLAGGED)
 652       i = a[7];
 653    if (mb.mb_threaded == 1 && mp->m_collapsed > 0)
 654       i = a[11];
 655    if (mb.mb_threaded == 1 && mp->m_collapsed < 0)
 656       i = a[10];
 657    NYD_LEAVE;
 658    return i;
 659 }
 660
 661 static int
 662 _scroll1(char *arg, int onlynew)
 663 {
 664    int cur[1], size;
 665    NYD_ENTER;
 666
 667    cur[0] = onlynew ? -1 : 0;
 668    size = screensize();
 669    switch (*arg) {
 670    case '1': case '2': case '3': case '4': case '5':
 671    case '6': case '7': case '8': case '9': case '0':
 672       _screen = atoi(arg);
 673       goto jscroll_forward;
 674    case '\0':
 675       ++_screen;
 676       goto jscroll_forward;
 677    case '$':
 678       _screen = msgCount / size;
 679       goto jscroll_forward;
 680    case '+':
 681       if (arg[1] == '\0')
 682          ++_screen;
 683       else
 684          _screen += atoi(arg + 1);
 685 jscroll_forward:
 686       if (_screen * size > msgCount) {
 687          _screen = msgCount / size;
 688          printf(_("On last screenful of messages\n"));
 689       }
 690       break;
 691
 692    case '-':
 693       if (arg[1] == '\0')
 694          --_screen;
 695       else
 696          _screen -= atoi(arg + 1);
 697       if (_screen < 0) {
 698          _screen = 0;
 699          printf(_("On first screenful of messages\n"));
 700       }
 701       if (cur[0] == -1)
 702          cur[0] = -2;
 703       break;
 704
 705    default:
 706       fprintf(stderr, _("Unrecognized scrolling command \"%s\"\n"), arg);
 707       size = 1;
 708       goto jleave;
 709    }
 710    size = c_headers(cur);
 711 jleave:
 712    NYD_LEAVE;
 713    return size;
 714 }
 715
 716 static int
 717 _type1(int *msgvec, bool_t doign, bool_t dopage, bool_t dopipe,
 718    bool_t dodecode, char *cmd, off_t *tstats)
 719 {
 720    off_t mstats[2];
 721    int rv, *ip;
 722    struct message *mp;
 723    char const *cp;
 724    FILE * volatile obuf;
 725    bool_t volatile hadsig = FAL0, isrelax = FAL0;
 726    NYD_ENTER;
 727    {/* C89.. */
 728    enum sendaction const action = ((dopipe && ok_blook(piperaw))
 729          ? SEND_MBOX : dodecode
 730          ? SEND_SHOW : doign
 731          ? SEND_TODISP : SEND_TODISP_ALL);
 732    bool_t const volatile formfeed = (dopipe && ok_blook(page));
 733    obuf = stdout;
 734
 735    if (sigsetjmp(_cmd1_pipestop, 1)) {
 736       hadsig = TRU1;
 737       goto jclose_pipe;
 738    }
 739
 740    if (dopipe) {
 741       if ((cp = ok_vlook(SHELL)) == NULL)
 742          cp = XSHELL;
 743       if ((obuf = Popen(cmd, "w", cp, NULL, 1)) == NULL) {
 744          perror(cmd);
 745          obuf = stdout;
 746       } else
 747          safe_signal(SIGPIPE, &_cmd1_brokpipe);
 748    } else if ((options & OPT_TTYOUT) &&
 749          (dopage || (cp = ok_vlook(crt)) != NULL)) {
 750       char const *pager = NULL;
 751       size_t nlines = 0;
 752
 753       if (!dopage) {
 754          for (ip = msgvec; *ip && PTRCMP(ip - msgvec, <, msgCount); ++ip) {
 755             mp = message + *ip - 1;
 756             if (!(mp->m_have & HAVE_BODY))
 757                if (get_body(mp) != OKAY) {
 758                   rv = 1;
 759                   goto jleave;
 760                }
 761             nlines += mp->m_lines + 1; /* Message info XXX and PARTS... */
 762          }
 763       }
 764
 765       /* `>=' not `<': we return to the prompt */
 766       if (dopage || UICMP(z, nlines, >=,
 767             (*cp != '\0' ? atoi(cp) : realscreenheight))) {
 768          char const *env_add[2];
 769          pager = get_pager(env_add + 0);
 770          env_add[1] = NULL;
 771          obuf = Popen(pager, "w", NULL, env_add, 1);
 772          if (obuf == NULL) {
 773             perror(pager);
 774             obuf = stdout;
 775             pager = NULL;
 776          } else
 777             safe_signal(SIGPIPE, &_cmd1_brokpipe);
 778       }
 779 #ifdef HAVE_COLOUR
 780       if (action != SEND_MBOX)
 781          colour_table_create(pager != NULL); /* (salloc()s!) */
 782 #endif
 783    }
 784 #ifdef HAVE_COLOUR
 785    else if ((options & OPT_TTYOUT) && action != SEND_MBOX)
 786       colour_table_create(FAL0); /* (salloc()s!) */
 787 #endif
 788
 789    /*TODO unless we have our signal manager special care must be taken */
 790    srelax_hold();
 791    isrelax = TRU1;
 792    for (ip = msgvec; *ip && PTRCMP(ip - msgvec, <, msgCount); ++ip) {
 793       mp = message + *ip - 1;
 794       touch(mp);
 795       setdot(mp);
 796       uncollapse1(mp, 1);
 797       if (!dopipe) {
 798          if (ip != msgvec)
 799             fprintf(obuf, "\n");
 800          if (action != SEND_MBOX)
 801             _show_msg_overview(obuf, mp, *ip);
 802       }
 803       sendmp(mp, obuf, (doign ? ignore : NULL), NULL, action, mstats);
 804       srelax();
 805       if (formfeed) /* TODO a nicer way to separate piped messages! */
 806          putc('\f', obuf);
 807       if (tstats) {
 808          tstats[0] += mstats[0];
 809          tstats[1] += mstats[1];
 810       }
 811    }
 812    srelax_rele();
 813    isrelax = FAL0;
 814
 815 jclose_pipe:
 816    if (obuf != stdout) {
 817       /* Ignore SIGPIPE so it can't cause a duplicate close */
 818       safe_signal(SIGPIPE, SIG_IGN);
 819       if (hadsig && isrelax)
 820          srelax_rele();
 821       colour_reset(obuf); /* XXX hacky; only here because we still jump */
 822       Pclose(obuf, TRU1);
 823       safe_signal(SIGPIPE, dflpipe);
 824    }
 825    rv = 0;
 826    }
 827 jleave:
 828    NYD_LEAVE;
 829    return rv;
 830 }
 831
 832 static int
 833 _pipe1(char *str, int doign)
 834 {
 835    off_t stats[2];
 836    char *cmd;
 837    int *msgvec, rv = 1;
 838    bool_t needs_list;
 839    NYD_ENTER;
 840
 841    if ((cmd = laststring(str, &needs_list, 1)) == NULL) {
 842       cmd = ok_vlook(cmd);
 843       if (cmd == NULL || *cmd == '\0') {
 844          fputs(_("variable cmd not set\n"), stderr);
 845          goto jleave;
 846       }
 847    }
 848
 849    msgvec = salloc((msgCount + 2) * sizeof *msgvec);
 850
 851    if (!needs_list) {
 852       *msgvec = first(0, MMNORM);
 853       if (*msgvec == 0) {
 854          if (inhook) {
 855             rv = 0;
 856             goto jleave;
 857          }
 858          puts(_("No messages to pipe."));
 859          goto jleave;
 860       }
 861       msgvec[1] = 0;
 862    } else if (getmsglist(str, msgvec, 0) < 0)
 863       goto jleave;
 864    if (*msgvec == 0) {
 865       if (inhook) {
 866          rv = 0;
 867          goto jleave;
 868       }
 869       printf("No applicable messages.\n");
 870       goto jleave;
 871    }
 872
 873    printf(_("Pipe to: \"%s\"\n"), cmd);
 874    stats[0] = stats[1] = 0;
 875    if ((rv = _type1(msgvec, doign, FAL0, TRU1, FAL0, cmd, stats)) == 0) {
 876       printf("\"%s\" ", cmd);
 877       if (stats[0] >= 0)
 878          printf("%lu", (long)stats[0]);
 879       else
 880          printf(_("binary"));
 881       printf("/%lu\n", (long)stats[1]);
 882    }
 883 jleave:
 884    NYD_LEAVE;
 885    return rv;
 886 }
 887
 888 FL int
 889 c_cmdnotsupp(void *v) /* TODO -> lex.c */
 890 {
 891    NYD_ENTER;
 892    UNUSED(v);
 893    fprintf(stderr, _("The requested feature is not compiled in\n"));
 894    NYD_LEAVE;
 895    return 1;
 896 }
 897
 898 FL int
 899 c_headers(void *v)
 900 {
 901    ui32_t flag;
 902    int *msgvec = v, g, k, n, mesg, size, lastg = 1;
 903    struct message *mp, *mq, *lastmq = NULL;
 904    enum mflag fl = MNEW | MFLAGGED;
 905    NYD_ENTER;
 906
 907    time_current_update(&time_current, FAL0);
 908
 909    flag = 0;
 910    size = screensize();
 911    n = msgvec[0]; /* n == {-2, -1, 0}: called from scroll() */
 912    if (_screen < 0)
 913       _screen = 0;
 914    k = _screen * size;
 915    if (k >= msgCount)
 916       k = msgCount - size;
 917    if (k < 0)
 918       k = 0;
 919
 920    if (mb.mb_threaded == 0) {
 921       g = 0;
 922       mq = message;
 923       for (mp = message; PTRCMP(mp, <, message + msgCount); ++mp)
 924          if (visible(mp)) {
 925             if (g % size == 0)
 926                mq = mp;
 927             if (mp->m_flag & fl) {
 928                lastg = g;
 929                lastmq = mq;
 930             }
 931             if ((n > 0 && PTRCMP(mp, ==, message + n - 1)) ||
 932                   (n == 0 && g == k) || (n == -2 && g == k + size && lastmq) ||
 933                   (n < 0 && g >= k && (mp->m_flag & fl) != 0))
 934                break;
 935             g++;
 936          }
 937       if (lastmq && (n == -2 ||
 938             (n == -1 && PTRCMP(mp, ==, message + msgCount)))) {
 939          g = lastg;
 940          mq = lastmq;
 941       }
 942       _screen = g / size;
 943       mp = mq;
 944       mesg = (int)PTR2SIZE(mp - message);
 945       if (PTRCMP(dot, !=, message + n - 1)) {
 946          for (mq = mp; PTRCMP(mq, <, message + msgCount); ++mq)
 947             if (visible(mq)) {
 948                setdot(mq);
 949                break;
 950             }
 951       }
 952 #ifdef HAVE_IMAP
 953       if (mb.mb_type == MB_IMAP)
 954          imap_getheaders(mesg + 1, mesg + size);
 955 #endif
 956       srelax_hold();
 957       for (; PTRCMP(mp, <, message + msgCount); ++mp) {
 958          ++mesg;
 959          if (!visible(mp))
 960             continue;
 961          if (UICMP(32, flag++, >=, size))
 962             break;
 963          _print_head(0, mesg, stdout, 0);
 964          srelax();
 965       }
 966       srelax_rele();
 967    } else { /* threaded */
 968       g = 0;
 969       mq = threadroot;
 970       for (mp = threadroot; mp; mp = next_in_thread(mp))
 971          if (visible(mp) &&
 972                (mp->m_collapsed <= 0 || PTRCMP(mp, ==, message + n - 1))) {
 973             if (g % size == 0)
 974                mq = mp;
 975             if (mp->m_flag & fl) {
 976                lastg = g;
 977                lastmq = mq;
 978             }
 979             if ((n > 0 && PTRCMP(mp, ==, message + n - 1)) ||
 980                   (n == 0 && g == k) || (n == -2 && g == k + size && lastmq) ||
 981                   (n < 0 && g >= k && (mp->m_flag & fl) != 0))
 982                break;
 983             g++;
 984          }
 985       if (lastmq && (n == -2 ||
 986             (n == -1 && PTRCMP(mp, ==, message + msgCount)))) {
 987          g = lastg;
 988          mq = lastmq;
 989       }
 990       _screen = g / size;
 991       mp = mq;
 992       if (PTRCMP(dot, !=, message + n - 1)) {
 993          for (mq = mp; mq; mq = next_in_thread(mq))
 994             if (visible(mq) && mq->m_collapsed <= 0) {
 995                setdot(mq);
 996                break;
 997             }
 998       }
 999       srelax_hold();
1000       while (mp) {
1001          if (visible(mp) &&
1002                (mp->m_collapsed <= 0 || PTRCMP(mp, ==, message + n - 1))) {
1003             if (UICMP(32, flag++, >=, size))
1004                break;
1005             _print_head(flag - 1, PTR2SIZE(mp - message + 1), stdout,
1006                mb.mb_threaded);
1007             srelax();
1008          }
1009          mp = next_in_thread(mp);
1010       }
1011       srelax_rele();
1012    }
1013
1014    if (!flag)
1015       printf(_("No more mail.\n"));
1016    NYD_LEAVE;
1017    return !flag;
1018 }
1019
1020 FL int
1021 c_scroll(void *v)
1022 {
1023    int rv;
1024    NYD_ENTER;
1025
1026    rv = _scroll1(v, 0);
1027    NYD_LEAVE;
1028    return rv;
1029 }
1030
1031 FL int
1032 c_Scroll(void *v)
1033 {
1034    int rv;
1035    NYD_ENTER;
1036
1037    rv = _scroll1(v, 1);
1038    NYD_LEAVE;
1039    return rv;
1040 }
1041
1042 FL int
1043 c_from(void *v)
1044 {
1045    int *msgvec = v, *ip, n;
1046    char *cp;
1047    FILE * volatile obuf;
1048    NYD_ENTER;
1049
1050    time_current_update(&time_current, FAL0);
1051    obuf = stdout;
1052
1053    /* TODO unfixable memory leaks still */
1054    if (IS_TTY_SESSION() && (cp = ok_vlook(crt)) != NULL) {
1055       for (n = 0, ip = msgvec; *ip != 0; ++ip)
1056          n++;
1057       if (n > (*cp == '\0' ? screensize() : atoi(cp)) + 3) {
1058          char const *p;
1059          if (sigsetjmp(_cmd1_pipejmp, 1))
1060             goto jendpipe;
1061          p = get_pager(NULL);
1062          if ((obuf = Popen(p, "w", NULL, NULL, 1)) == NULL) {
1063             perror(p);
1064             obuf = stdout;
1065             cp = NULL;
1066          } else
1067             safe_signal(SIGPIPE, &_cmd1_onpipe);
1068       }
1069    }
1070
1071    for (n = 0, ip = msgvec; *ip != 0; ++ip) /* TODO join into _print_head() */
1072       _print_head((size_t)n++, (size_t)*ip, obuf, mb.mb_threaded);
1073    if (--ip >= msgvec)
1074       setdot(message + *ip - 1);
1075
1076 jendpipe:
1077    if (obuf != stdout) {
1078       safe_signal(SIGPIPE, SIG_IGN);
1079       Pclose(obuf, TRU1);
1080       safe_signal(SIGPIPE, dflpipe);
1081    }
1082    NYD_LEAVE;
1083    return 0;
1084 }
1085
1086 FL void
1087 print_headers(size_t bottom, size_t topx, bool_t only_marked)
1088 {
1089    size_t printed;
1090    NYD_ENTER;
1091
1092 #ifdef HAVE_IMAP
1093    if (mb.mb_type == MB_IMAP)
1094       imap_getheaders(bottom, topx);
1095 #endif
1096    time_current_update(&time_current, FAL0);
1097
1098    for (printed = 0; bottom <= topx; ++bottom) {
1099       struct message *mp = message + bottom - 1;
1100       if (only_marked) {
1101          if (!(mp->m_flag & MMARK))
1102             continue;
1103       } else if (!visible(mp))
1104          continue;
1105       _print_head(printed++, bottom, stdout, FAL0);
1106    }
1107    NYD_LEAVE;
1108 }
1109
1110 FL int
1111 c_pdot(void *v)
1112 {
1113    NYD_ENTER;
1114    UNUSED(v);
1115    printf("%d\n", (int)PTR2SIZE(dot - message + 1));
1116    NYD_LEAVE;
1117    return 0;
1118 }
1119
1120 FL int
1121 c_more(void *v)
1122 {
1123    int *msgvec = v, rv;
1124    NYD_ENTER;
1125
1126    rv = _type1(msgvec, TRU1, TRU1, FAL0, FAL0, NULL, NULL);
1127    NYD_LEAVE;
1128    return rv;
1129 }
1130
1131 FL int
1132 c_More(void *v)
1133 {
1134    int *msgvec = v, rv;
1135    NYD_ENTER;
1136
1137    rv = _type1(msgvec, FAL0, TRU1, FAL0, FAL0, NULL, NULL);
1138    NYD_LEAVE;
1139    return rv;
1140 }
1141
1142 FL int
1143 c_type(void *v)
1144 {
1145    int *msgvec = v, rv;
1146    NYD_ENTER;
1147
1148    rv = _type1(msgvec, TRU1, FAL0, FAL0, FAL0, NULL, NULL);
1149    NYD_LEAVE;
1150    return rv;
1151 }
1152
1153 FL int
1154 c_Type(void *v)
1155 {
1156    int *msgvec = v, rv;
1157    NYD_ENTER;
1158
1159    rv = _type1(msgvec, FAL0, FAL0, FAL0, FAL0, NULL, NULL);
1160    NYD_LEAVE;
1161    return rv;
1162 }
1163
1164 FL int
1165 c_show(void *v)
1166 {
1167    int *msgvec = v, rv;
1168    NYD_ENTER;
1169
1170    rv = _type1(msgvec, FAL0, FAL0, FAL0, TRU1, NULL, NULL);
1171    NYD_LEAVE;
1172    return rv;
1173 }
1174
1175 FL int
1176 c_pipe(void *v)
1177 {
1178    char *str = v;
1179    int rv;
1180    NYD_ENTER;
1181
1182    rv = _pipe1(str, 1);
1183    NYD_LEAVE;
1184    return rv;
1185 }
1186
1187 FL int
1188 c_Pipe(void *v)
1189 {
1190    char *str = v;
1191    int rv;
1192    NYD_ENTER;
1193
1194    rv = _pipe1(str, 0);
1195    NYD_LEAVE;
1196    return rv;
1197 }
1198
1199 FL int
1200 c_top(void *v)
1201 {
1202    int *msgvec = v, *ip, c, topl, lines, empty_last;
1203    struct message *mp;
1204    char *cp, *linebuf = NULL;
1205    size_t linesize = 0;
1206    FILE *ibuf;
1207    NYD_ENTER;
1208
1209    topl = 5;
1210    cp = ok_vlook(toplines);
1211    if (cp != NULL) {
1212       topl = atoi(cp);
1213       if (topl < 0 || topl > 10000)
1214          topl = 5;
1215    }
1216
1217 #ifdef HAVE_COLOUR
1218    if (options & OPT_TTYOUT)
1219       colour_table_create(FAL0); /* (salloc()s) */
1220 #endif
1221    empty_last = 1;
1222    for (ip = msgvec; *ip != 0 && UICMP(z, PTR2SIZE(ip - msgvec), <, msgCount);
1223          ++ip) {
1224       mp = message + *ip - 1;
1225       touch(mp);
1226       setdot(mp);
1227       did_print_dot = TRU1;
1228       if (!empty_last)
1229          printf("\n");
1230       _show_msg_overview(stdout, mp, *ip);
1231       if (mp->m_flag & MNOFROM)
1232          /* XXX c_top(): coloured output? */
1233          printf("From %s %s\n", fakefrom(mp), fakedate(mp->m_time));
1234       if ((ibuf = setinput(&mb, mp, NEED_BODY)) == NULL) {  /* XXX could use TOP */
1235          v = NULL;
1236          break;
1237       }
1238       c = mp->m_lines;
1239       for (lines = 0; lines < c && UICMP(32, lines, <=, topl); ++lines) {
1240          if (readline_restart(ibuf, &linebuf, &linesize, 0) < 0)
1241             break;
1242          puts(linebuf);
1243
1244          for (cp = linebuf; *cp != '\0' && blankchar(*cp); ++cp)
1245             ;
1246          empty_last = (*cp == '\0');
1247       }
1248    }
1249
1250    if (linebuf != NULL)
1251       free(linebuf);
1252    NYD_LEAVE;
1253    return (v != NULL);
1254 }
1255
1256 FL int
1257 c_stouch(void *v)
1258 {
1259    int *msgvec = v, *ip;
1260    NYD_ENTER;
1261
1262    for (ip = msgvec; *ip != 0; ++ip) {
1263       setdot(message + *ip - 1);
1264       dot->m_flag |= MTOUCH;
1265       dot->m_flag &= ~MPRESERVE;
1266       did_print_dot = TRU1;
1267    }
1268    NYD_LEAVE;
1269    return 0;
1270 }
1271
1272 FL int
1273 c_mboxit(void *v)
1274 {
1275    int *msgvec = v, *ip;
1276    NYD_ENTER;
1277
1278    for (ip = msgvec; *ip != 0; ++ip) {
1279       setdot(message + *ip - 1);
1280       dot->m_flag |= MTOUCH | MBOX;
1281       dot->m_flag &= ~MPRESERVE;
1282       did_print_dot = TRU1;
1283    }
1284    NYD_LEAVE;
1285    return 0;
1286 }
1287
1288 FL int
1289 c_folders(void *v)
1290 {
1291    char dirname[PATH_MAX], *name, **argv = v;
1292    char const *cmd;
1293    int rv = 1;
1294    NYD_ENTER;
1295
1296    if (*argv) {
1297       name = expand(*argv);
1298       if (name == NULL)
1299          goto jleave;
1300    } else if (!getfold(dirname, sizeof dirname)) {
1301       fprintf(stderr, _("No value set for \"folder\"\n"));
1302       goto jleave;
1303    } else
1304       name = dirname;
1305
1306    if (which_protocol(name) == PROTO_IMAP) {
1307 #ifdef HAVE_IMAP
1308       imap_folders(name, *argv == NULL);
1309 #else
1310       rv = c_cmdnotsupp(NULL);
1311 #endif
1312    } else {
1313       if ((cmd = ok_vlook(LISTER)) == NULL)
1314          cmd = XLISTER;
1315       run_command(cmd, 0, -1, -1, name, NULL, NULL);
1316    }
1317 jleave:
1318    NYD_LEAVE;
1319    return rv;
1320 }
1321
1322 /* s-it-mode */