imap-search.c

   1 /*@ S-nail - a mail user agent derived from Berkeley Mail.
   2  *@ Client-side implementation of the IMAP SEARCH command. This is used
   3  *@ for folders not located on IMAP servers, or for IMAP servers that do
   4  *@ not implement the SEARCH command.
   5  *
   6  * Copyright (c) 2000-2004 Gunnar Ritter, Freiburg i. Br., Germany.
   7  * Copyright (c) 2012 - 2017 Steffen (Daode) Nurpmeso <steffen@sdaoden.eu>.
   8  */
   9 /*
  10  * Copyright (c) 2004
  11  * Gunnar Ritter.  All rights reserved.
  12  *
  13  * Redistribution and use in source and binary forms, with or without
  14  * modification, are permitted provided that the following conditions
  15  * are met:
  16  * 1. Redistributions of source code must retain the above copyright
  17  *    notice, this list of conditions and the following disclaimer.
  18  * 2. Redistributions in binary form must reproduce the above copyright
  19  *    notice, this list of conditions and the following disclaimer in the
  20  *    documentation and/or other materials provided with the distribution.
  21  * 3. All advertising materials mentioning features or use of this software
  22  *    must display the following acknowledgement:
  23  *    This product includes software developed by Gunnar Ritter
  24  *    and his contributors.
  25  * 4. Neither the name of Gunnar Ritter nor the names of his contributors
  26  *    may be used to endorse or promote products derived from this software
  27  *    without specific prior written permission.
  28  *
  29  * THIS SOFTWARE IS PROVIDED BY GUNNAR RITTER AND CONTRIBUTORS ``AS IS'' AND
  30  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
  31  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
  32  * ARE DISCLAIMED.  IN NO EVENT SHALL GUNNAR RITTER OR CONTRIBUTORS BE LIABLE
  33  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
  34  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
  35  * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
  36  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
  37  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
  38  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
  39  * SUCH DAMAGE.
  40  */
  41 #undef n_FILE
  42 #define n_FILE imap_search
  43
  44 #ifndef HAVE_AMALGAMATION
  45 # include "nail.h"
  46 #endif
  47
  48 EMPTY_FILE()
  49 #ifdef HAVE_IMAP_SEARCH
  50
  51 enum itoken {
  52    ITBAD, ITEOD, ITBOL, ITEOL, ITAND, ITSET, ITALL, ITANSWERED,
  53    ITBCC, ITBEFORE, ITBODY,
  54    ITCC,
  55    ITDELETED, ITDRAFT,
  56    ITFLAGGED, ITFROM,
  57    ITHEADER,
  58    ITKEYWORD,
  59    ITLARGER,
  60    ITNEW, ITNOT,
  61    ITOLD, ITON, ITOR,
  62    ITRECENT,
  63    ITSEEN, ITSENTBEFORE, ITSENTON, ITSENTSINCE, ITSINCE, ITSMALLER,
  64       ITSUBJECT,
  65    ITTEXT, ITTO,
  66    ITUID, ITUNANSWERED, ITUNDELETED, ITUNDRAFT, ITUNFLAGGED, ITUNKEYWORD,
  67       ITUNSEEN
  68 };
  69
  70 struct itlex {
  71    char const     *s_string;
  72    enum itoken    s_token;
  73 };
  74
  75 struct itnode {
  76    enum itoken    n_token;
  77    uiz_t          n_n;
  78    void           *n_v;
  79    void           *n_w;
  80    struct itnode  *n_x;
  81    struct itnode  *n_y;
  82 };
  83
  84 static struct itlex const  _it_strings[] = {
  85    { "ALL",          ITALL },
  86    { "ANSWERED",     ITANSWERED },
  87    { "BCC",          ITBCC },
  88    { "BEFORE",       ITBEFORE },
  89    { "BODY",         ITBODY },
  90    { "CC",           ITCC },
  91    { "DELETED",      ITDELETED },
  92    { "DRAFT",        ITDRAFT },
  93    { "FLAGGED",      ITFLAGGED },
  94    { "FROM",         ITFROM },
  95    { "HEADER",       ITHEADER },
  96    { "KEYWORD",      ITKEYWORD },
  97    { "LARGER",       ITLARGER },
  98    { "NEW",          ITNEW },
  99    { "NOT",          ITNOT },
 100    { "OLD",          ITOLD },
 101    { "ON",           ITON },
 102    { "OR",           ITOR },
 103    { "RECENT",       ITRECENT },
 104    { "SEEN",         ITSEEN },
 105    { "SENTBEFORE",   ITSENTBEFORE },
 106    { "SENTON",       ITSENTON },
 107    { "SENTSINCE",    ITSENTSINCE },
 108    { "SINCE",        ITSINCE },
 109    { "SMALLER",      ITSMALLER },
 110    { "SUBJECT",      ITSUBJECT },
 111    { "TEXT",         ITTEXT },
 112    { "TO",           ITTO },
 113    { "UID",          ITUID },
 114    { "UNANSWERED",   ITUNANSWERED },
 115    { "UNDELETED",    ITUNDELETED },
 116    { "UNDRAFT",      ITUNDRAFT },
 117    { "UNFLAGGED",    ITUNFLAGGED },
 118    { "UNKEYWORD",    ITUNKEYWORD },
 119    { "UNSEEN",       ITUNSEEN },
 120    { NULL,           ITBAD }
 121 };
 122
 123 static struct itnode    *_it_tree;
 124 static char             *_it_begin;
 125 static enum itoken      _it_token;
 126 static uiz_t            _it_number;
 127 static void             *_it_args[2];
 128 static size_t           _it_need_headers;
 129
 130 static enum okay     itparse(char const *spec, char const **xp, int sub);
 131 static enum okay     itscan(char const *spec, char const **xp);
 132 static enum okay     itsplit(char const *spec, char const **xp);
 133 static enum okay     itstring(void **tp, char const *spec, char const **xp);
 134 static int           itexecute(struct mailbox *mp, struct message *m,
 135                         size_t c, struct itnode *n);
 136
 137 static time_t        _imap_read_date(char const *cp);
 138 static char *        _imap_quotestr(char const *s);
 139 static char *        _imap_unquotestr(char const *s);
 140
 141 static bool_t        matchfield(struct message *m, char const *field,
 142                         void const *what);
 143 static int           matchenvelope(struct message *m, char const *field,
 144                         void const *what);
 145 static char *        mkenvelope(struct name *np);
 146 static char const *  around(char const *cp);
 147
 148 static enum okay
 149 itparse(char const *spec, char const **xp, int sub)
 150 {
 151    int level = 0;
 152    struct itnode n, *z, *ittree;
 153    enum okay rv;
 154    NYD_ENTER;
 155
 156    _it_tree = NULL;
 157    while ((rv = itscan(spec, xp)) == OKAY && _it_token != ITBAD &&
 158          _it_token != ITEOD) {
 159       ittree = _it_tree;
 160       memset(&n, 0, sizeof n);
 161       spec = *xp;
 162       switch (_it_token) {
 163       case ITBOL:
 164          ++level;
 165          continue;
 166       case ITEOL:
 167          if (--level == 0)
 168             goto jleave;
 169          if (level < 0) {
 170             if (sub > 0) {
 171                --(*xp);
 172                goto jleave;
 173             }
 174             n_err(_("Excess in )\n"));
 175             rv = STOP;
 176             goto jleave;
 177          }
 178          continue;
 179       case ITNOT:
 180          /* <search-key> */
 181          n.n_token = ITNOT;
 182          if ((rv = itparse(spec, xp, sub + 1)) == STOP)
 183             goto jleave;
 184          spec = *xp;
 185          if ((n.n_x = _it_tree) == NULL) {
 186             n_err(_("Criterion for NOT missing: >>> %s <<<\n"), around(*xp));
 187             rv = STOP;
 188             goto jleave;
 189          }
 190          _it_token = ITNOT;
 191          break;
 192       case ITOR:
 193          /* <search-key1> <search-key2> */
 194          n.n_token = ITOR;
 195          if ((rv = itparse(spec, xp, sub + 1)) == STOP)
 196             goto jleave;
 197          if ((n.n_x = _it_tree) == NULL) {
 198             n_err(_("First criterion for OR missing: >>> %s <<<\n"),
 199                around(*xp));
 200             rv = STOP;
 201             goto jleave;
 202          }
 203          spec = *xp;
 204          if ((rv = itparse(spec, xp, sub + 1)) == STOP)
 205             goto jleave;
 206          spec = *xp;
 207          if ((n.n_y = _it_tree) == NULL) {
 208             n_err(_("Second criterion for OR missing: >>> %s <<<\n"),
 209                around(*xp));
 210             rv = STOP;
 211             goto jleave;
 212          }
 213          break;
 214       default:
 215          n.n_token = _it_token;
 216          n.n_n = _it_number;
 217          n.n_v = _it_args[0];
 218          n.n_w = _it_args[1];
 219       }
 220
 221       _it_tree = ittree;
 222       if (_it_tree == NULL) {
 223          _it_tree = salloc(sizeof *_it_tree);
 224          *_it_tree = n;
 225       } else {
 226          z = _it_tree;
 227          _it_tree = salloc(sizeof *_it_tree);
 228          _it_tree->n_token = ITAND;
 229          _it_tree->n_x = z;
 230          _it_tree->n_y = salloc(sizeof *_it_tree->n_y);
 231          *_it_tree->n_y = n;
 232       }
 233       if (sub && level == 0)
 234          break;
 235    }
 236 jleave:
 237    NYD_LEAVE;
 238    return rv;
 239 }
 240
 241 static enum okay
 242 itscan(char const *spec, char const **xp)
 243 {
 244    int i, n;
 245    enum okay rv = OKAY;
 246    NYD_ENTER;
 247
 248    while (spacechar(*spec))
 249       ++spec;
 250    if (*spec == '(') {
 251       *xp = &spec[1];
 252       _it_token = ITBOL;
 253       goto jleave;
 254    }
 255    if (*spec == ')') {
 256       *xp = &spec[1];
 257       _it_token = ITEOL;
 258       goto jleave;
 259    }
 260    while (spacechar(*spec))
 261       ++spec;
 262    if (*spec == '\0') {
 263       _it_token = ITEOD;
 264       goto jleave;
 265    }
 266
 267 #define __GO(C)   ((C) != '\0' && (C) != '(' && (C) != ')' && !spacechar(C))
 268    for (i = 0; _it_strings[i].s_string != NULL; ++i) {
 269       n = strlen(_it_strings[i].s_string);
 270       if (!ascncasecmp(spec, _it_strings[i].s_string, n) && !__GO(spec[n])) {
 271          _it_token = _it_strings[i].s_token;
 272          spec += n;
 273          while (spacechar(*spec))
 274             ++spec;
 275          rv = itsplit(spec, xp);
 276          goto jleave;
 277       }
 278    }
 279    if (digitchar(*spec)) {
 280       n_idec_uiz_cp(&_it_number, spec, 10, xp);
 281       if (!__GO(**xp)) {
 282          _it_token = ITSET;
 283          goto jleave;
 284       }
 285    }
 286
 287    n_err(_("Bad SEARCH criterion: "));
 288    for (i = 0; __GO(spec[i]); ++i)
 289       ;
 290    n_err(_("%.*s: >>> %s <<<\n"), i, spec, around(*xp));
 291 #undef __GO
 292
 293    _it_token = ITBAD;
 294    rv = STOP;
 295 jleave:
 296    NYD_LEAVE;
 297    return rv;
 298 }
 299
 300 static enum okay
 301 itsplit(char const *spec, char const **xp)
 302 {
 303    char const *cp;
 304    time_t t;
 305    enum okay rv;
 306    NYD_ENTER;
 307
 308    switch (_it_token) {
 309    case ITBCC:
 310    case ITBODY:
 311    case ITCC:
 312    case ITFROM:
 313    case ITSUBJECT:
 314    case ITTEXT:
 315    case ITTO:
 316       /* <string> */
 317       ++_it_need_headers;
 318       rv = itstring(_it_args, spec, xp);
 319       break;
 320    case ITSENTBEFORE:
 321    case ITSENTON:
 322    case ITSENTSINCE:
 323       ++_it_need_headers;
 324       /*FALLTHRU*/
 325    case ITBEFORE:
 326    case ITON:
 327    case ITSINCE:
 328       /* <date> */
 329       if ((rv = itstring(_it_args, spec, xp)) != OKAY)
 330          break;
 331       if ((t = _imap_read_date(_it_args[0])) == (time_t)-1) {
 332          n_err(_("Invalid date %s: >>> %s <<<\n"),
 333             (char*)_it_args[0], around(*xp));
 334          rv = STOP;
 335          break;
 336       }
 337       _it_number = t;
 338       rv = OKAY;
 339       break;
 340    case ITHEADER:
 341       /* <field-name> <string> */
 342       ++_it_need_headers;
 343       if ((rv = itstring(_it_args, spec, xp)) != OKAY)
 344          break;
 345       spec = *xp;
 346       if ((rv = itstring(_it_args + 1, spec, xp)) != OKAY)
 347          break;
 348       break;
 349    case ITKEYWORD:
 350    case ITUNKEYWORD:
 351       /* <flag> */ /* TODO use table->flag map search instead */
 352       if ((rv = itstring(_it_args, spec, xp)) != OKAY)
 353          break;
 354       if (!asccasecmp(_it_args[0], "\\Seen"))
 355          _it_number = MREAD;
 356       else if (!asccasecmp(_it_args[0], "\\Deleted"))
 357          _it_number = MDELETED;
 358       else if (!asccasecmp(_it_args[0], "\\Recent"))
 359          _it_number = MNEW;
 360       else if (!asccasecmp(_it_args[0], "\\Flagged"))
 361          _it_number = MFLAGGED;
 362       else if (!asccasecmp(_it_args[0], "\\Answered"))
 363          _it_number = MANSWERED;
 364       else if (!asccasecmp(_it_args[0], "\\Draft"))
 365          _it_number = MDRAFT;
 366       else
 367          _it_number = 0;
 368       break;
 369    case ITLARGER:
 370    case ITSMALLER:
 371       /* <n> */
 372       if ((rv = itstring(_it_args, spec, xp)) != OKAY)
 373          break;
 374       else{
 375          n_idec_uiz_cp(&_it_number, _it_args[0], 10, &cp);
 376       }
 377       if (spacechar(*cp) || *cp == '\0')
 378          break;
 379       n_err(_("Invalid size: >>> %s <<<\n"), around(*xp));
 380       rv = STOP;
 381       break;
 382    case ITUID:
 383       /* <message set> */
 384       n_err(_("Searching for UIDs is not supported: >>> %s <<<\n"),
 385          around(*xp));
 386       rv = STOP;
 387       break;
 388    default:
 389       *xp = spec;
 390       rv = OKAY;
 391       break;
 392    }
 393    NYD_LEAVE;
 394    return rv;
 395 }
 396
 397 static enum okay
 398 itstring(void **tp, char const *spec, char const **xp) /* XXX lesser derefs */
 399 {
 400    int inquote = 0;
 401    char *ap;
 402    enum okay rv = STOP;
 403    NYD_ENTER;
 404
 405    while (spacechar(*spec))
 406       ++spec;
 407    if (*spec == '\0' || *spec == '(' || *spec == ')') {
 408       n_err(_("Missing string argument: >>> %s <<<\n"),
 409          around(&(*xp)[spec - *xp]));
 410       goto jleave;
 411    }
 412    ap = *tp = salloc(strlen(spec) +1);
 413    *xp = spec;
 414     do {
 415       if (inquote && **xp == '\\')
 416          *ap++ = *(*xp)++;
 417       else if (**xp == '"')
 418          inquote = !inquote;
 419       else if (!inquote && (spacechar(**xp) || **xp == '(' || **xp == ')')) {
 420          *ap++ = '\0';
 421          break;
 422       }
 423       *ap++ = **xp;
 424    } while (*(*xp)++);
 425
 426    *tp = _imap_unquotestr(*tp);
 427    rv = OKAY;
 428 jleave:
 429    NYD_LEAVE;
 430    return rv;
 431 }
 432
 433 static int
 434 itexecute(struct mailbox *mp, struct message *m, size_t c, struct itnode *n)
 435 {
 436    struct search_expr se;
 437    char *cp, *line = NULL; /* TODO line pool */
 438    size_t linesize = 0;
 439    FILE *ibuf;
 440    int rv;
 441    NYD_ENTER;
 442
 443    if (n == NULL) {
 444       n_err(_("Internal error: Empty node in SEARCH tree\n"));
 445       rv = 0;
 446       goto jleave;
 447    }
 448
 449    switch (n->n_token) {
 450    case ITBEFORE:
 451    case ITON:
 452    case ITSINCE:
 453       if (m->m_time == 0 && !(m->m_flag & MNOFROM) &&
 454             (ibuf = setinput(mp, m, NEED_HEADER)) != NULL) {
 455          if (readline_restart(ibuf, &line, &linesize, 0) > 0)
 456             m->m_time = unixtime(line);
 457          free(line);
 458       }
 459       break;
 460    case ITSENTBEFORE:
 461    case ITSENTON:
 462    case ITSENTSINCE:
 463       if (m->m_date == 0)
 464          if ((cp = hfield1("date", m)) != NULL)
 465             m->m_date = rfctime(cp);
 466       break;
 467    default:
 468       break;
 469    }
 470
 471    switch (n->n_token) {
 472    default:
 473       n_err(_("Internal SEARCH error: Lost token %d\n"), n->n_token);
 474       rv = 0;
 475       break;
 476    case ITAND:
 477       rv = itexecute(mp, m, c, n->n_x) & itexecute(mp, m, c, n->n_y);
 478       break;
 479    case ITSET:
 480       rv = (c == n->n_n);
 481       break;
 482    case ITALL:
 483       rv = 1;
 484       break;
 485    case ITANSWERED:
 486       rv = ((m->m_flag & MANSWERED) != 0);
 487       break;
 488    case ITBCC:
 489       rv = matchenvelope(m, "bcc", n->n_v);
 490       break;
 491    case ITBEFORE:
 492       rv = UICMP(z, m->m_time, <, n->n_n);
 493       break;
 494    case ITBODY:
 495       se.ss_sexpr = n->n_v;
 496       se.ss_where = "body";
 497       rv = message_match(m, &se, FAL0);
 498       break;
 499    case ITCC:
 500       rv = matchenvelope(m, "cc", n->n_v);
 501       break;
 502    case ITDELETED:
 503       rv = ((m->m_flag & MDELETED) != 0);
 504       break;
 505    case ITDRAFT:
 506       rv = ((m->m_flag & MDRAFTED) != 0);
 507       break;
 508    case ITFLAGGED:
 509       rv = ((m->m_flag & MFLAGGED) != 0);
 510       break;
 511    case ITFROM:
 512       rv = matchenvelope(m, "from", n->n_v);
 513       break;
 514    case ITHEADER:
 515       rv = matchfield(m, n->n_v, n->n_w);
 516       break;
 517    case ITKEYWORD:
 518       rv = ((m->m_flag & n->n_n) != 0);
 519       break;
 520    case ITLARGER:
 521       rv = (m->m_xsize > n->n_n);
 522       break;
 523    case ITNEW:
 524       rv = ((m->m_flag & (MNEW | MREAD)) == MNEW);
 525       break;
 526    case ITNOT:
 527       rv = !itexecute(mp, m, c, n->n_x);
 528       break;
 529    case ITOLD:
 530       rv = !(m->m_flag & MNEW);
 531       break;
 532    case ITON:
 533       rv = (UICMP(z, m->m_time, >=, n->n_n) &&
 534             UICMP(z, m->m_time, <, n->n_n + 86400));
 535       break;
 536    case ITOR:
 537       rv = itexecute(mp, m, c, n->n_x) | itexecute(mp, m, c, n->n_y);
 538       break;
 539    case ITRECENT:
 540       rv = ((m->m_flag & MNEW) != 0);
 541       break;
 542    case ITSEEN:
 543       rv = ((m->m_flag & MREAD) != 0);
 544       break;
 545    case ITSENTBEFORE:
 546       rv = UICMP(z, m->m_date, <, n->n_n);
 547       break;
 548    case ITSENTON:
 549       rv = (UICMP(z, m->m_date, >=, n->n_n) &&
 550             UICMP(z, m->m_date, <, n->n_n + 86400));
 551       break;
 552    case ITSENTSINCE:
 553       rv = UICMP(z, m->m_date, >=, n->n_n);
 554       break;
 555    case ITSINCE:
 556       rv = UICMP(z, m->m_time, >=, n->n_n);
 557       break;
 558    case ITSMALLER:
 559       rv = UICMP(z, m->m_xsize, <, n->n_n);
 560       break;
 561    case ITSUBJECT:
 562       rv = matchfield(m, "subject", n->n_v);
 563       break;
 564    case ITTEXT:
 565       se.ss_sexpr = n->n_v;
 566       se.ss_where = "text";
 567       rv = message_match(m, &se, TRU1);
 568       break;
 569    case ITTO:
 570       rv = matchenvelope(m, "to", n->n_v);
 571       break;
 572    case ITUNANSWERED:
 573       rv = !(m->m_flag & MANSWERED);
 574       break;
 575    case ITUNDELETED:
 576       rv = !(m->m_flag & MDELETED);
 577       break;
 578    case ITUNDRAFT:
 579       rv = !(m->m_flag & MDRAFTED);
 580       break;
 581    case ITUNFLAGGED:
 582       rv = !(m->m_flag & MFLAGGED);
 583       break;
 584    case ITUNKEYWORD:
 585       rv = !(m->m_flag & n->n_n);
 586       break;
 587    case ITUNSEEN:
 588       rv = !(m->m_flag & MREAD);
 589       break;
 590    }
 591 jleave:
 592    NYD_LEAVE;
 593    return rv;
 594 }
 595
 596 static time_t
 597 _imap_read_date(char const *cp)
 598 {
 599    time_t t = (time_t)-1;
 600    si32_t year, month, day, i, tzdiff;
 601    struct tm *tmptr;
 602    char const *xp, *yp;
 603    NYD_ENTER;
 604
 605    if (*cp == '"')
 606       ++cp;
 607    n_idec_si32_cp(&day, cp, 10, &xp);
 608    if (day <= 0 || day > 31 || *xp++ != '-')
 609       goto jleave;
 610
 611    for (i = 0;;) {
 612       if (!ascncasecmp(xp, n_month_names[i], 3))
 613          break;
 614       if (n_month_names[++i][0] == '\0')
 615          goto jleave;
 616    }
 617    month = i + 1;
 618    if (xp[3] != '-')
 619       goto jleave;
 620    n_idec_si32_cp(&year, &xp[4], 10, &yp);
 621    if (year < 1970 || year > 2037 || PTRCMP(yp, !=, xp + 8))
 622       goto jleave;
 623    if (yp[0] != '\0' && (yp[1] != '"' || yp[2] != '\0'))
 624       goto jleave;
 625    if ((t = combinetime(year, month, day, 0, 0, 0)) == (time_t)-1)
 626       goto jleave;
 627    tzdiff = t - mktime(gmtime(&t));
 628    tmptr = localtime(&t);
 629    if (tmptr->tm_isdst > 0)
 630       tzdiff += 3600;
 631    t -= tzdiff;
 632 jleave:
 633    NYD_LEAVE;
 634    return t;
 635 }
 636
 637 static char *
 638 _imap_quotestr(char const *s)
 639 {
 640    char *n, *np;
 641    NYD2_ENTER;
 642
 643    np = n = salloc(2 * strlen(s) + 3);
 644    *np++ = '"';
 645    while (*s) {
 646       if (*s == '"' || *s == '\\')
 647          *np++ = '\\';
 648       *np++ = *s++;
 649    }
 650    *np++ = '"';
 651    *np = '\0';
 652    NYD2_LEAVE;
 653    return n;
 654 }
 655
 656 static char *
 657 _imap_unquotestr(char const *s)
 658 {
 659    char *n, *np;
 660    NYD2_ENTER;
 661
 662    if (*s != '"') {
 663       n = savestr(s);
 664       goto jleave;
 665    }
 666
 667    np = n = salloc(strlen(s) + 1);
 668    while (*++s) {
 669       if (*s == '\\')
 670          s++;
 671       else if (*s == '"')
 672          break;
 673       *np++ = *s;
 674    }
 675    *np = '\0';
 676 jleave:
 677    NYD2_LEAVE;
 678    return n;
 679 }
 680
 681 static bool_t
 682 matchfield(struct message *m, char const *field, void const *what)
 683 {
 684    struct str in, out;
 685    bool_t rv = FAL0;
 686    NYD_ENTER;
 687
 688    if ((in.s = hfieldX(field, m)) == NULL)
 689       goto jleave;
 690
 691    in.l = strlen(in.s);
 692    mime_fromhdr(&in, &out, TD_ICONV);
 693    rv = substr(out.s, what);
 694    free(out.s);
 695 jleave:
 696    NYD_LEAVE;
 697    return rv;
 698 }
 699
 700 static int
 701 matchenvelope(struct message *m, char const *field, void const *what)
 702 {
 703    struct name *np;
 704    char *cp;
 705    int rv = 0;
 706    NYD_ENTER;
 707
 708    if ((cp = hfieldX(field, m)) == NULL)
 709       goto jleave;
 710
 711    for (np = lextract(cp, GFULL); np != NULL; np = np->n_flink) {
 712       if (!substr(np->n_name, what) && !substr(mkenvelope(np), what))
 713          continue;
 714       rv = 1;
 715       break;
 716    }
 717
 718 jleave:
 719    NYD_LEAVE;
 720    return rv;
 721 }
 722
 723 static char *
 724 mkenvelope(struct name *np)
 725 {
 726    size_t epsize;
 727    char *ep, *realnam = NULL, *sourceaddr = NULL, *localpart = NULL,
 728       *domainpart = NULL, *cp, *rp, *xp, *ip;
 729    struct str in, out;
 730    int level = 0;
 731    bool_t hadphrase = FAL0;
 732    NYD_ENTER;
 733
 734    in.s = np->n_fullname;
 735    in.l = strlen(in.s);
 736    mime_fromhdr(&in, &out, TD_ICONV);
 737    rp = ip = ac_alloc(strlen(out.s) + 1);
 738    for (cp = out.s; *cp; cp++) {
 739       switch (*cp) {
 740       case '"':
 741          while (*cp) {
 742             if (*++cp == '"')
 743                break;
 744             if (cp[0] == '\\' && cp[1] != '\0')
 745                ++cp;
 746             *rp++ = *cp;
 747          }
 748          break;
 749       case '<':
 750          while (cp > out.s && blankchar(cp[-1]))
 751             --cp;
 752          rp = ip;
 753          xp = out.s;
 754          if (PTRCMP(xp, <, cp - 1) && *xp == '"' && cp[-1] == '"') {
 755             ++xp;
 756             --cp;
 757          }
 758          while (xp < cp)
 759             *rp++ = *xp++;
 760          hadphrase = TRU1;
 761          goto jdone;
 762       case '(':
 763          if (level++)
 764             goto jdfl;
 765          if (!hadphrase)
 766             rp = ip;
 767          hadphrase = TRU1;
 768          break;
 769       case ')':
 770          if (--level)
 771             goto jdfl;
 772          break;
 773       case '\\':
 774          if (level && cp[1] != '\0')
 775             cp++;
 776          goto jdfl;
 777       default:
 778 jdfl:
 779          *rp++ = *cp;
 780       }
 781    }
 782 jdone:
 783    *rp = '\0';
 784    if (hadphrase)
 785       realnam = ip;
 786    free(out.s);
 787    localpart = savestr(np->n_name);
 788    if ((cp = strrchr(localpart, '@')) != NULL) {
 789       *cp = '\0';
 790       domainpart = cp + 1;
 791    }
 792
 793    ep = n_autorec_alloc(epsize = strlen(np->n_fullname) * 2 + 40);
 794    snprintf(ep, epsize, "(%s %s %s %s)",
 795       realnam ? _imap_quotestr(realnam) : "NIL",
 796       sourceaddr ? _imap_quotestr(sourceaddr) : "NIL",
 797       localpart ? _imap_quotestr(localpart) : "NIL",
 798       domainpart ? _imap_quotestr(domainpart) : "NIL");
 799    ac_free(ip);
 800    NYD_LEAVE;
 801    return ep;
 802 }
 803
 804 #define SURROUNDING 16
 805 static char const *
 806 around(char const *cp)
 807 {
 808    static char ab[2 * SURROUNDING +1];
 809
 810    size_t i;
 811    NYD_ENTER;
 812
 813    for (i = 0; i < SURROUNDING && cp > _it_begin; ++i)
 814       --cp;
 815    for (i = 0; i < sizeof(ab) -1; ++i)
 816       ab[i] = *cp++;
 817    ab[i] = '\0';
 818    NYD_LEAVE;
 819    return ab;
 820 }
 821
 822 FL ssize_t
 823 imap_search(char const *spec, int f)
 824 {
 825    static char *lastspec;
 826
 827    char const *xp;
 828    size_t i;
 829    ssize_t rv;
 830    NYD_ENTER;
 831
 832    if (strcmp(spec, "()")) {
 833       if (lastspec != NULL)
 834          free(lastspec);
 835       i = strlen(spec);
 836       lastspec = sbufdup(spec, i);
 837    } else if (lastspec == NULL) {
 838       n_err(_("No last SEARCH criteria available\n"));
 839       rv = -1;
 840       goto jleave;
 841    }
 842    spec =
 843    _it_begin = lastspec;
 844
 845    _it_need_headers = FAL0;
 846 #ifdef HAVE_IMAP
 847    if ((rv = imap_search1(spec, f) == OKAY))
 848       goto jleave;
 849 #endif
 850    if (itparse(spec, &xp, 0) == STOP){
 851       rv = -1;
 852       goto jleave;
 853    }
 854
 855    rv = 0;
 856
 857    if (_it_tree == NULL)
 858       goto jleave;
 859
 860 #ifdef HAVE_IMAP
 861    if (mb.mb_type == MB_IMAP && _it_need_headers)
 862       imap_getheaders(1, msgCount);
 863 #endif
 864    srelax_hold();
 865    for (i = 0; UICMP(z, i, <, msgCount); ++i) {
 866       if (message[i].m_flag & MHIDDEN)
 867          continue;
 868       if (f == MDELETED || !(message[i].m_flag & MDELETED)) {
 869          size_t j = (int)(i + 1);
 870          if (itexecute(&mb, message + i, j, _it_tree)){
 871             mark((int)j, f);
 872             ++rv;
 873          }
 874          srelax();
 875       }
 876    }
 877    srelax_rele();
 878 jleave:
 879    NYD_LEAVE;
 880    return rv;
 881 }
 882 #endif /* HAVE_IMAP_SEARCH */
 883
 884 /* s-it-mode */