src/src/expand.c

   1 /*************************************************
   2 *     Exim - an Internet mail transport agent    *
   3 *************************************************/
   4
   5 /* Copyright (c) University of Cambridge 1995 - 2014 */
   6 /* See the file NOTICE for conditions of use and distribution. */
   7
   8
   9 /* Functions for handling string expansion. */
  10
  11
  12 #include "exim.h"
  13
  14 /* Recursively called function */
  15
  16 static uschar *expand_string_internal(uschar *, BOOL, uschar **, BOOL, BOOL, BOOL *);
  17
  18 #ifdef STAND_ALONE
  19 #ifndef SUPPORT_CRYPTEQ
  20 #define SUPPORT_CRYPTEQ
  21 #endif
  22 #endif
  23
  24 #ifdef LOOKUP_LDAP
  25 #include "lookups/ldap.h"
  26 #endif
  27
  28 #ifdef SUPPORT_CRYPTEQ
  29 #ifdef CRYPT_H
  30 #include <crypt.h>
  31 #endif
  32 #ifndef HAVE_CRYPT16
  33 extern char* crypt16(char*, char*);
  34 #endif
  35 #endif
  36
  37 /* The handling of crypt16() is a mess. I will record below the analysis of the
  38 mess that was sent to me. We decided, however, to make changing this very low
  39 priority, because in practice people are moving away from the crypt()
  40 algorithms nowadays, so it doesn't seem worth it.
  41
  42 <quote>
  43 There is an algorithm named "crypt16" in Ultrix and Tru64.  It crypts
  44 the first 8 characters of the password using a 20-round version of crypt
  45 (standard crypt does 25 rounds).  It then crypts the next 8 characters,
  46 or an empty block if the password is less than 9 characters, using a
  47 20-round version of crypt and the same salt as was used for the first
  48 block.  Charaters after the first 16 are ignored.  It always generates
  49 a 16-byte hash, which is expressed together with the salt as a string
  50 of 24 base 64 digits.  Here are some links to peruse:
  51
  52         http://cvs.pld.org.pl/pam/pamcrypt/crypt16.c?rev=1.2
  53         http://seclists.org/bugtraq/1999/Mar/0076.html
  54
  55 There's a different algorithm named "bigcrypt" in HP-UX, Digital Unix,
  56 and OSF/1.  This is the same as the standard crypt if given a password
  57 of 8 characters or less.  If given more, it first does the same as crypt
  58 using the first 8 characters, then crypts the next 8 (the 9th to 16th)
  59 using as salt the first two base 64 digits from the first hash block.
  60 If the password is more than 16 characters then it crypts the 17th to 24th
  61 characters using as salt the first two base 64 digits from the second hash
  62 block.  And so on: I've seen references to it cutting off the password at
  63 40 characters (5 blocks), 80 (10 blocks), or 128 (16 blocks).  Some links:
  64
  65         http://cvs.pld.org.pl/pam/pamcrypt/bigcrypt.c?rev=1.2
  66         http://seclists.org/bugtraq/1999/Mar/0109.html
  67         http://h30097.www3.hp.com/docs/base_doc/DOCUMENTATION/HTML/AA-Q0R2D-
  68              TET1_html/sec.c222.html#no_id_208
  69
  70 Exim has something it calls "crypt16".  It will either use a native
  71 crypt16 or its own implementation.  A native crypt16 will presumably
  72 be the one that I called "crypt16" above.  The internal "crypt16"
  73 function, however, is a two-block-maximum implementation of what I called
  74 "bigcrypt".  The documentation matches the internal code.
  75
  76 I suspect that whoever did the "crypt16" stuff for Exim didn't realise
  77 that crypt16 and bigcrypt were different things.
  78
  79 Exim uses the LDAP-style scheme identifier "{crypt16}" to refer
  80 to whatever it is using under that name.  This unfortunately sets a
  81 precedent for using "{crypt16}" to identify two incompatible algorithms
  82 whose output can't be distinguished.  With "{crypt16}" thus rendered
  83 ambiguous, I suggest you deprecate it and invent two new identifiers
  84 for the two algorithms.
  85
  86 Both crypt16 and bigcrypt are very poor algorithms, btw.  Hashing parts
  87 of the password separately means they can be cracked separately, so
  88 the double-length hash only doubles the cracking effort instead of
  89 squaring it.  I recommend salted SHA-1 ({SSHA}), or the Blowfish-based
  90 bcrypt ({CRYPT}$2a$).
  91 </quote>
  92 */
  93
  94
  95
  96 #ifndef nelements
  97 # define nelements(arr) (sizeof(arr) / sizeof(*arr))
  98 #endif
  99
 100 /*************************************************
 101 *            Local statics and tables            *
 102 *************************************************/
 103
 104 /* Table of item names, and corresponding switch numbers. The names must be in
 105 alphabetical order. */
 106
 107 static uschar *item_table[] = {
 108   US"acl",
 109   US"certextract",
 110   US"dlfunc",
 111   US"extract",
 112   US"filter",
 113   US"hash",
 114   US"hmac",
 115   US"if",
 116   US"length",
 117   US"listextract",
 118   US"lookup",
 119   US"map",
 120   US"nhash",
 121   US"perl",
 122   US"prvs",
 123   US"prvscheck",
 124   US"readfile",
 125   US"readsocket",
 126   US"reduce",
 127   US"run",
 128   US"sg",
 129   US"substr",
 130   US"tr" };
 131
 132 enum {
 133   EITEM_ACL,
 134   EITEM_CERTEXTRACT,
 135   EITEM_DLFUNC,
 136   EITEM_EXTRACT,
 137   EITEM_FILTER,
 138   EITEM_HASH,
 139   EITEM_HMAC,
 140   EITEM_IF,
 141   EITEM_LENGTH,
 142   EITEM_LISTEXTRACT,
 143   EITEM_LOOKUP,
 144   EITEM_MAP,
 145   EITEM_NHASH,
 146   EITEM_PERL,
 147   EITEM_PRVS,
 148   EITEM_PRVSCHECK,
 149   EITEM_READFILE,
 150   EITEM_READSOCK,
 151   EITEM_REDUCE,
 152   EITEM_RUN,
 153   EITEM_SG,
 154   EITEM_SUBSTR,
 155   EITEM_TR };
 156
 157 /* Tables of operator names, and corresponding switch numbers. The names must be
 158 in alphabetical order. There are two tables, because underscore is used in some
 159 cases to introduce arguments, whereas for other it is part of the name. This is
 160 an historical mis-design. */
 161
 162 static uschar *op_table_underscore[] = {
 163   US"from_utf8",
 164   US"local_part",
 165   US"quote_local_part",
 166   US"reverse_ip",
 167   US"time_eval",
 168   US"time_interval"};
 169
 170 enum {
 171   EOP_FROM_UTF8,
 172   EOP_LOCAL_PART,
 173   EOP_QUOTE_LOCAL_PART,
 174   EOP_REVERSE_IP,
 175   EOP_TIME_EVAL,
 176   EOP_TIME_INTERVAL };
 177
 178 static uschar *op_table_main[] = {
 179   US"address",
 180   US"addresses",
 181   US"base62",
 182   US"base62d",
 183   US"domain",
 184   US"escape",
 185   US"eval",
 186   US"eval10",
 187   US"expand",
 188   US"h",
 189   US"hash",
 190   US"hex2b64",
 191   US"hexquote",
 192   US"l",
 193   US"lc",
 194   US"length",
 195   US"listcount",
 196   US"listnamed",
 197   US"mask",
 198   US"md5",
 199   US"nh",
 200   US"nhash",
 201   US"quote",
 202   US"randint",
 203   US"rfc2047",
 204   US"rfc2047d",
 205   US"rxquote",
 206   US"s",
 207   US"sha1",
 208   US"stat",
 209   US"str2b64",
 210   US"strlen",
 211   US"substr",
 212   US"uc",
 213   US"utf8clean" };
 214
 215 enum {
 216   EOP_ADDRESS =  sizeof(op_table_underscore)/sizeof(uschar *),
 217   EOP_ADDRESSES,
 218   EOP_BASE62,
 219   EOP_BASE62D,
 220   EOP_DOMAIN,
 221   EOP_ESCAPE,
 222   EOP_EVAL,
 223   EOP_EVAL10,
 224   EOP_EXPAND,
 225   EOP_H,
 226   EOP_HASH,
 227   EOP_HEX2B64,
 228   EOP_HEXQUOTE,
 229   EOP_L,
 230   EOP_LC,
 231   EOP_LENGTH,
 232   EOP_LISTCOUNT,
 233   EOP_LISTNAMED,
 234   EOP_MASK,
 235   EOP_MD5,
 236   EOP_NH,
 237   EOP_NHASH,
 238   EOP_QUOTE,
 239   EOP_RANDINT,
 240   EOP_RFC2047,
 241   EOP_RFC2047D,
 242   EOP_RXQUOTE,
 243   EOP_S,
 244   EOP_SHA1,
 245   EOP_STAT,
 246   EOP_STR2B64,
 247   EOP_STRLEN,
 248   EOP_SUBSTR,
 249   EOP_UC,
 250   EOP_UTF8CLEAN };
 251
 252
 253 /* Table of condition names, and corresponding switch numbers. The names must
 254 be in alphabetical order. */
 255
 256 static uschar *cond_table[] = {
 257   US"<",
 258   US"<=",
 259   US"=",
 260   US"==",     /* Backward compatibility */
 261   US">",
 262   US">=",
 263   US"acl",
 264   US"and",
 265   US"bool",
 266   US"bool_lax",
 267   US"crypteq",
 268   US"def",
 269   US"eq",
 270   US"eqi",
 271   US"exists",
 272   US"first_delivery",
 273   US"forall",
 274   US"forany",
 275   US"ge",
 276   US"gei",
 277   US"gt",
 278   US"gti",
 279   US"inlist",
 280   US"inlisti",
 281   US"isip",
 282   US"isip4",
 283   US"isip6",
 284   US"ldapauth",
 285   US"le",
 286   US"lei",
 287   US"lt",
 288   US"lti",
 289   US"match",
 290   US"match_address",
 291   US"match_domain",
 292   US"match_ip",
 293   US"match_local_part",
 294   US"or",
 295   US"pam",
 296   US"pwcheck",
 297   US"queue_running",
 298   US"radius",
 299   US"saslauthd"
 300 };
 301
 302 enum {
 303   ECOND_NUM_L,
 304   ECOND_NUM_LE,
 305   ECOND_NUM_E,
 306   ECOND_NUM_EE,
 307   ECOND_NUM_G,
 308   ECOND_NUM_GE,
 309   ECOND_ACL,
 310   ECOND_AND,
 311   ECOND_BOOL,
 312   ECOND_BOOL_LAX,
 313   ECOND_CRYPTEQ,
 314   ECOND_DEF,
 315   ECOND_STR_EQ,
 316   ECOND_STR_EQI,
 317   ECOND_EXISTS,
 318   ECOND_FIRST_DELIVERY,
 319   ECOND_FORALL,
 320   ECOND_FORANY,
 321   ECOND_STR_GE,
 322   ECOND_STR_GEI,
 323   ECOND_STR_GT,
 324   ECOND_STR_GTI,
 325   ECOND_INLIST,
 326   ECOND_INLISTI,
 327   ECOND_ISIP,
 328   ECOND_ISIP4,
 329   ECOND_ISIP6,
 330   ECOND_LDAPAUTH,
 331   ECOND_STR_LE,
 332   ECOND_STR_LEI,
 333   ECOND_STR_LT,
 334   ECOND_STR_LTI,
 335   ECOND_MATCH,
 336   ECOND_MATCH_ADDRESS,
 337   ECOND_MATCH_DOMAIN,
 338   ECOND_MATCH_IP,
 339   ECOND_MATCH_LOCAL_PART,
 340   ECOND_OR,
 341   ECOND_PAM,
 342   ECOND_PWCHECK,
 343   ECOND_QUEUE_RUNNING,
 344   ECOND_RADIUS,
 345   ECOND_SASLAUTHD
 346 };
 347
 348
 349 /* Type for main variable table */
 350
 351 typedef struct {
 352   const char *name;
 353   int         type;
 354   void       *value;
 355 } var_entry;
 356
 357 /* Type for entries pointing to address/length pairs. Not currently
 358 in use. */
 359
 360 typedef struct {
 361   uschar **address;
 362   int  *length;
 363 } alblock;
 364
 365 /* Types of table entry */
 366
 367 enum {
 368   vtype_int,            /* value is address of int */
 369   vtype_filter_int,     /* ditto, but recognized only when filtering */
 370   vtype_ino,            /* value is address of ino_t (not always an int) */
 371   vtype_uid,            /* value is address of uid_t (not always an int) */
 372   vtype_gid,            /* value is address of gid_t (not always an int) */
 373   vtype_bool,           /* value is address of bool */
 374   vtype_stringptr,      /* value is address of pointer to string */
 375   vtype_msgbody,        /* as stringptr, but read when first required */
 376   vtype_msgbody_end,    /* ditto, the end of the message */
 377   vtype_msgheaders,     /* the message's headers, processed */
 378   vtype_msgheaders_raw, /* the message's headers, unprocessed */
 379   vtype_localpart,      /* extract local part from string */
 380   vtype_domain,         /* extract domain from string */
 381   vtype_string_func,    /* value is string returned by given function */
 382   vtype_todbsdin,       /* value not used; generate BSD inbox tod */
 383   vtype_tode,           /* value not used; generate tod in epoch format */
 384   vtype_todel,          /* value not used; generate tod in epoch/usec format */
 385   vtype_todf,           /* value not used; generate full tod */
 386   vtype_todl,           /* value not used; generate log tod */
 387   vtype_todlf,          /* value not used; generate log file datestamp tod */
 388   vtype_todzone,        /* value not used; generate time zone only */
 389   vtype_todzulu,        /* value not used; generate zulu tod */
 390   vtype_reply,          /* value not used; get reply from headers */
 391   vtype_pid,            /* value not used; result is pid */
 392   vtype_host_lookup,    /* value not used; get host name */
 393   vtype_load_avg,       /* value not used; result is int from os_getloadavg */
 394   vtype_pspace,         /* partition space; value is T/F for spool/log */
 395   vtype_pinodes,        /* partition inodes; value is T/F for spool/log */
 396   vtype_cert            /* SSL certificate */
 397   #ifndef DISABLE_DKIM
 398   ,vtype_dkim           /* Lookup of value in DKIM signature */
 399   #endif
 400   };
 401
 402 static uschar * fn_recipients(void);
 403
 404 /* This table must be kept in alphabetical order. */
 405
 406 static var_entry var_table[] = {
 407   /* WARNING: Do not invent variables whose names start acl_c or acl_m because
 408      they will be confused with user-creatable ACL variables. */
 409   { "acl_arg1",            vtype_stringptr,   &acl_arg[0] },
 410   { "acl_arg2",            vtype_stringptr,   &acl_arg[1] },
 411   { "acl_arg3",            vtype_stringptr,   &acl_arg[2] },
 412   { "acl_arg4",            vtype_stringptr,   &acl_arg[3] },
 413   { "acl_arg5",            vtype_stringptr,   &acl_arg[4] },
 414   { "acl_arg6",            vtype_stringptr,   &acl_arg[5] },
 415   { "acl_arg7",            vtype_stringptr,   &acl_arg[6] },
 416   { "acl_arg8",            vtype_stringptr,   &acl_arg[7] },
 417   { "acl_arg9",            vtype_stringptr,   &acl_arg[8] },
 418   { "acl_narg",            vtype_int,         &acl_narg },
 419   { "acl_verify_message",  vtype_stringptr,   &acl_verify_message },
 420   { "address_data",        vtype_stringptr,   &deliver_address_data },
 421   { "address_file",        vtype_stringptr,   &address_file },
 422   { "address_pipe",        vtype_stringptr,   &address_pipe },
 423   { "authenticated_fail_id",vtype_stringptr,  &authenticated_fail_id },
 424   { "authenticated_id",    vtype_stringptr,   &authenticated_id },
 425   { "authenticated_sender",vtype_stringptr,   &authenticated_sender },
 426   { "authentication_failed",vtype_int,        &authentication_failed },
 427 #ifdef WITH_CONTENT_SCAN
 428   { "av_failed",           vtype_int,         &av_failed },
 429 #endif
 430 #ifdef EXPERIMENTAL_BRIGHTMAIL
 431   { "bmi_alt_location",    vtype_stringptr,   &bmi_alt_location },
 432   { "bmi_base64_tracker_verdict", vtype_stringptr, &bmi_base64_tracker_verdict },
 433   { "bmi_base64_verdict",  vtype_stringptr,   &bmi_base64_verdict },
 434   { "bmi_deliver",         vtype_int,         &bmi_deliver },
 435 #endif
 436   { "body_linecount",      vtype_int,         &body_linecount },
 437   { "body_zerocount",      vtype_int,         &body_zerocount },
 438   { "bounce_recipient",    vtype_stringptr,   &bounce_recipient },
 439   { "bounce_return_size_limit", vtype_int,    &bounce_return_size_limit },
 440   { "caller_gid",          vtype_gid,         &real_gid },
 441   { "caller_uid",          vtype_uid,         &real_uid },
 442   { "compile_date",        vtype_stringptr,   &version_date },
 443   { "compile_number",      vtype_stringptr,   &version_cnumber },
 444   { "csa_status",          vtype_stringptr,   &csa_status },
 445 #ifdef EXPERIMENTAL_DCC
 446   { "dcc_header",          vtype_stringptr,   &dcc_header },
 447   { "dcc_result",          vtype_stringptr,   &dcc_result },
 448 #endif
 449 #ifdef WITH_OLD_DEMIME
 450   { "demime_errorlevel",   vtype_int,         &demime_errorlevel },
 451   { "demime_reason",       vtype_stringptr,   &demime_reason },
 452 #endif
 453 #ifndef DISABLE_DKIM
 454   { "dkim_algo",           vtype_dkim,        (void *)DKIM_ALGO },
 455   { "dkim_bodylength",     vtype_dkim,        (void *)DKIM_BODYLENGTH },
 456   { "dkim_canon_body",     vtype_dkim,        (void *)DKIM_CANON_BODY },
 457   { "dkim_canon_headers",  vtype_dkim,        (void *)DKIM_CANON_HEADERS },
 458   { "dkim_copiedheaders",  vtype_dkim,        (void *)DKIM_COPIEDHEADERS },
 459   { "dkim_created",        vtype_dkim,        (void *)DKIM_CREATED },
 460   { "dkim_cur_signer",     vtype_stringptr,   &dkim_cur_signer },
 461   { "dkim_domain",         vtype_stringptr,   &dkim_signing_domain },
 462   { "dkim_expires",        vtype_dkim,        (void *)DKIM_EXPIRES },
 463   { "dkim_headernames",    vtype_dkim,        (void *)DKIM_HEADERNAMES },
 464   { "dkim_identity",       vtype_dkim,        (void *)DKIM_IDENTITY },
 465   { "dkim_key_granularity",vtype_dkim,        (void *)DKIM_KEY_GRANULARITY },
 466   { "dkim_key_nosubdomains",vtype_dkim,       (void *)DKIM_NOSUBDOMAINS },
 467   { "dkim_key_notes",      vtype_dkim,        (void *)DKIM_KEY_NOTES },
 468   { "dkim_key_srvtype",    vtype_dkim,        (void *)DKIM_KEY_SRVTYPE },
 469   { "dkim_key_testing",    vtype_dkim,        (void *)DKIM_KEY_TESTING },
 470   { "dkim_selector",       vtype_stringptr,   &dkim_signing_selector },
 471   { "dkim_signers",        vtype_stringptr,   &dkim_signers },
 472   { "dkim_verify_reason",  vtype_dkim,        (void *)DKIM_VERIFY_REASON },
 473   { "dkim_verify_status",  vtype_dkim,        (void *)DKIM_VERIFY_STATUS},
 474 #endif
 475 #ifdef EXPERIMENTAL_DMARC
 476   { "dmarc_ar_header",     vtype_stringptr,   &dmarc_ar_header },
 477   { "dmarc_domain_policy", vtype_stringptr,   &dmarc_domain_policy },
 478   { "dmarc_status",        vtype_stringptr,   &dmarc_status },
 479   { "dmarc_status_text",   vtype_stringptr,   &dmarc_status_text },
 480   { "dmarc_used_domain",   vtype_stringptr,   &dmarc_used_domain },
 481 #endif
 482   { "dnslist_domain",      vtype_stringptr,   &dnslist_domain },
 483   { "dnslist_matched",     vtype_stringptr,   &dnslist_matched },
 484   { "dnslist_text",        vtype_stringptr,   &dnslist_text },
 485   { "dnslist_value",       vtype_stringptr,   &dnslist_value },
 486   { "domain",              vtype_stringptr,   &deliver_domain },
 487   { "domain_data",         vtype_stringptr,   &deliver_domain_data },
 488   { "exim_gid",            vtype_gid,         &exim_gid },
 489   { "exim_path",           vtype_stringptr,   &exim_path },
 490   { "exim_uid",            vtype_uid,         &exim_uid },
 491 #ifdef WITH_OLD_DEMIME
 492   { "found_extension",     vtype_stringptr,   &found_extension },
 493 #endif
 494   { "headers_added",       vtype_string_func, &fn_hdrs_added },
 495   { "home",                vtype_stringptr,   &deliver_home },
 496   { "host",                vtype_stringptr,   &deliver_host },
 497   { "host_address",        vtype_stringptr,   &deliver_host_address },
 498   { "host_data",           vtype_stringptr,   &host_data },
 499   { "host_lookup_deferred",vtype_int,         &host_lookup_deferred },
 500   { "host_lookup_failed",  vtype_int,         &host_lookup_failed },
 501   { "inode",               vtype_ino,         &deliver_inode },
 502   { "interface_address",   vtype_stringptr,   &interface_address },
 503   { "interface_port",      vtype_int,         &interface_port },
 504   { "item",                vtype_stringptr,   &iterate_item },
 505   #ifdef LOOKUP_LDAP
 506   { "ldap_dn",             vtype_stringptr,   &eldap_dn },
 507   #endif
 508   { "load_average",        vtype_load_avg,    NULL },
 509   { "local_part",          vtype_stringptr,   &deliver_localpart },
 510   { "local_part_data",     vtype_stringptr,   &deliver_localpart_data },
 511   { "local_part_prefix",   vtype_stringptr,   &deliver_localpart_prefix },
 512   { "local_part_suffix",   vtype_stringptr,   &deliver_localpart_suffix },
 513   { "local_scan_data",     vtype_stringptr,   &local_scan_data },
 514   { "local_user_gid",      vtype_gid,         &local_user_gid },
 515   { "local_user_uid",      vtype_uid,         &local_user_uid },
 516   { "localhost_number",    vtype_int,         &host_number },
 517   { "log_inodes",          vtype_pinodes,     (void *)FALSE },
 518   { "log_space",           vtype_pspace,      (void *)FALSE },
 519   { "lookup_dnssec_authenticated",vtype_stringptr,&lookup_dnssec_authenticated},
 520   { "mailstore_basename",  vtype_stringptr,   &mailstore_basename },
 521 #ifdef WITH_CONTENT_SCAN
 522   { "malware_name",        vtype_stringptr,   &malware_name },
 523 #endif
 524   { "max_received_linelength", vtype_int,     &max_received_linelength },
 525   { "message_age",         vtype_int,         &message_age },
 526   { "message_body",        vtype_msgbody,     &message_body },
 527   { "message_body_end",    vtype_msgbody_end, &message_body_end },
 528   { "message_body_size",   vtype_int,         &message_body_size },
 529   { "message_exim_id",     vtype_stringptr,   &message_id },
 530   { "message_headers",     vtype_msgheaders,  NULL },
 531   { "message_headers_raw", vtype_msgheaders_raw, NULL },
 532   { "message_id",          vtype_stringptr,   &message_id },
 533   { "message_linecount",   vtype_int,         &message_linecount },
 534   { "message_size",        vtype_int,         &message_size },
 535 #ifdef WITH_CONTENT_SCAN
 536   { "mime_anomaly_level",  vtype_int,         &mime_anomaly_level },
 537   { "mime_anomaly_text",   vtype_stringptr,   &mime_anomaly_text },
 538   { "mime_boundary",       vtype_stringptr,   &mime_boundary },
 539   { "mime_charset",        vtype_stringptr,   &mime_charset },
 540   { "mime_content_description", vtype_stringptr, &mime_content_description },
 541   { "mime_content_disposition", vtype_stringptr, &mime_content_disposition },
 542   { "mime_content_id",     vtype_stringptr,   &mime_content_id },
 543   { "mime_content_size",   vtype_int,         &mime_content_size },
 544   { "mime_content_transfer_encoding",vtype_stringptr, &mime_content_transfer_encoding },
 545   { "mime_content_type",   vtype_stringptr,   &mime_content_type },
 546   { "mime_decoded_filename", vtype_stringptr, &mime_decoded_filename },
 547   { "mime_filename",       vtype_stringptr,   &mime_filename },
 548   { "mime_is_coverletter", vtype_int,         &mime_is_coverletter },
 549   { "mime_is_multipart",   vtype_int,         &mime_is_multipart },
 550   { "mime_is_rfc822",      vtype_int,         &mime_is_rfc822 },
 551   { "mime_part_count",     vtype_int,         &mime_part_count },
 552 #endif
 553   { "n0",                  vtype_filter_int,  &filter_n[0] },
 554   { "n1",                  vtype_filter_int,  &filter_n[1] },
 555   { "n2",                  vtype_filter_int,  &filter_n[2] },
 556   { "n3",                  vtype_filter_int,  &filter_n[3] },
 557   { "n4",                  vtype_filter_int,  &filter_n[4] },
 558   { "n5",                  vtype_filter_int,  &filter_n[5] },
 559   { "n6",                  vtype_filter_int,  &filter_n[6] },
 560   { "n7",                  vtype_filter_int,  &filter_n[7] },
 561   { "n8",                  vtype_filter_int,  &filter_n[8] },
 562   { "n9",                  vtype_filter_int,  &filter_n[9] },
 563   { "original_domain",     vtype_stringptr,   &deliver_domain_orig },
 564   { "original_local_part", vtype_stringptr,   &deliver_localpart_orig },
 565   { "originator_gid",      vtype_gid,         &originator_gid },
 566   { "originator_uid",      vtype_uid,         &originator_uid },
 567   { "parent_domain",       vtype_stringptr,   &deliver_domain_parent },
 568   { "parent_local_part",   vtype_stringptr,   &deliver_localpart_parent },
 569   { "pid",                 vtype_pid,         NULL },
 570   { "primary_hostname",    vtype_stringptr,   &primary_hostname },
 571 #ifdef EXPERIMENTAL_PROXY
 572   { "proxy_host_address",  vtype_stringptr,   &proxy_host_address },
 573   { "proxy_host_port",     vtype_int,         &proxy_host_port },
 574   { "proxy_session",       vtype_bool,        &proxy_session },
 575   { "proxy_target_address",vtype_stringptr,   &proxy_target_address },
 576   { "proxy_target_port",   vtype_int,         &proxy_target_port },
 577 #endif
 578   { "prvscheck_address",   vtype_stringptr,   &prvscheck_address },
 579   { "prvscheck_keynum",    vtype_stringptr,   &prvscheck_keynum },
 580   { "prvscheck_result",    vtype_stringptr,   &prvscheck_result },
 581   { "qualify_domain",      vtype_stringptr,   &qualify_domain_sender },
 582   { "qualify_recipient",   vtype_stringptr,   &qualify_domain_recipient },
 583   { "rcpt_count",          vtype_int,         &rcpt_count },
 584   { "rcpt_defer_count",    vtype_int,         &rcpt_defer_count },
 585   { "rcpt_fail_count",     vtype_int,         &rcpt_fail_count },
 586   { "received_count",      vtype_int,         &received_count },
 587   { "received_for",        vtype_stringptr,   &received_for },
 588   { "received_ip_address", vtype_stringptr,   &interface_address },
 589   { "received_port",       vtype_int,         &interface_port },
 590   { "received_protocol",   vtype_stringptr,   &received_protocol },
 591   { "received_time",       vtype_int,         &received_time },
 592   { "recipient_data",      vtype_stringptr,   &recipient_data },
 593   { "recipient_verify_failure",vtype_stringptr,&recipient_verify_failure },
 594   { "recipients",          vtype_string_func, &fn_recipients },
 595   { "recipients_count",    vtype_int,         &recipients_count },
 596 #ifdef WITH_CONTENT_SCAN
 597   { "regex_match_string",  vtype_stringptr,   &regex_match_string },
 598 #endif
 599   { "reply_address",       vtype_reply,       NULL },
 600   { "return_path",         vtype_stringptr,   &return_path },
 601   { "return_size_limit",   vtype_int,         &bounce_return_size_limit },
 602   { "router_name",         vtype_stringptr,   &router_name },
 603   { "runrc",               vtype_int,         &runrc },
 604   { "self_hostname",       vtype_stringptr,   &self_hostname },
 605   { "sender_address",      vtype_stringptr,   &sender_address },
 606   { "sender_address_data", vtype_stringptr,   &sender_address_data },
 607   { "sender_address_domain", vtype_domain,    &sender_address },
 608   { "sender_address_local_part", vtype_localpart, &sender_address },
 609   { "sender_data",         vtype_stringptr,   &sender_data },
 610   { "sender_fullhost",     vtype_stringptr,   &sender_fullhost },
 611   { "sender_helo_name",    vtype_stringptr,   &sender_helo_name },
 612   { "sender_host_address", vtype_stringptr,   &sender_host_address },
 613   { "sender_host_authenticated",vtype_stringptr, &sender_host_authenticated },
 614   { "sender_host_dnssec",  vtype_bool,        &sender_host_dnssec },
 615   { "sender_host_name",    vtype_host_lookup, NULL },
 616   { "sender_host_port",    vtype_int,         &sender_host_port },
 617   { "sender_ident",        vtype_stringptr,   &sender_ident },
 618   { "sender_rate",         vtype_stringptr,   &sender_rate },
 619   { "sender_rate_limit",   vtype_stringptr,   &sender_rate_limit },
 620   { "sender_rate_period",  vtype_stringptr,   &sender_rate_period },
 621   { "sender_rcvhost",      vtype_stringptr,   &sender_rcvhost },
 622   { "sender_verify_failure",vtype_stringptr,  &sender_verify_failure },
 623   { "sending_ip_address",  vtype_stringptr,   &sending_ip_address },
 624   { "sending_port",        vtype_int,         &sending_port },
 625   { "smtp_active_hostname", vtype_stringptr,  &smtp_active_hostname },
 626   { "smtp_command",        vtype_stringptr,   &smtp_cmd_buffer },
 627   { "smtp_command_argument", vtype_stringptr, &smtp_cmd_argument },
 628   { "smtp_count_at_connection_start", vtype_int, &smtp_accept_count },
 629   { "smtp_notquit_reason", vtype_stringptr,   &smtp_notquit_reason },
 630   { "sn0",                 vtype_filter_int,  &filter_sn[0] },
 631   { "sn1",                 vtype_filter_int,  &filter_sn[1] },
 632   { "sn2",                 vtype_filter_int,  &filter_sn[2] },
 633   { "sn3",                 vtype_filter_int,  &filter_sn[3] },
 634   { "sn4",                 vtype_filter_int,  &filter_sn[4] },
 635   { "sn5",                 vtype_filter_int,  &filter_sn[5] },
 636   { "sn6",                 vtype_filter_int,  &filter_sn[6] },
 637   { "sn7",                 vtype_filter_int,  &filter_sn[7] },
 638   { "sn8",                 vtype_filter_int,  &filter_sn[8] },
 639   { "sn9",                 vtype_filter_int,  &filter_sn[9] },
 640 #ifdef WITH_CONTENT_SCAN
 641   { "spam_bar",            vtype_stringptr,   &spam_bar },
 642   { "spam_report",         vtype_stringptr,   &spam_report },
 643   { "spam_score",          vtype_stringptr,   &spam_score },
 644   { "spam_score_int",      vtype_stringptr,   &spam_score_int },
 645 #endif
 646 #ifdef EXPERIMENTAL_SPF
 647   { "spf_guess",           vtype_stringptr,   &spf_guess },
 648   { "spf_header_comment",  vtype_stringptr,   &spf_header_comment },
 649   { "spf_received",        vtype_stringptr,   &spf_received },
 650   { "spf_result",          vtype_stringptr,   &spf_result },
 651   { "spf_smtp_comment",    vtype_stringptr,   &spf_smtp_comment },
 652 #endif
 653   { "spool_directory",     vtype_stringptr,   &spool_directory },
 654   { "spool_inodes",        vtype_pinodes,     (void *)TRUE },
 655   { "spool_space",         vtype_pspace,      (void *)TRUE },
 656 #ifdef EXPERIMENTAL_SRS
 657   { "srs_db_address",      vtype_stringptr,   &srs_db_address },
 658   { "srs_db_key",          vtype_stringptr,   &srs_db_key },
 659   { "srs_orig_recipient",  vtype_stringptr,   &srs_orig_recipient },
 660   { "srs_orig_sender",     vtype_stringptr,   &srs_orig_sender },
 661   { "srs_recipient",       vtype_stringptr,   &srs_recipient },
 662   { "srs_status",          vtype_stringptr,   &srs_status },
 663 #endif
 664   { "thisaddress",         vtype_stringptr,   &filter_thisaddress },
 665
 666   /* The non-(in,out) variables are now deprecated */
 667   { "tls_bits",            vtype_int,         &tls_in.bits },
 668   { "tls_certificate_verified", vtype_int,    &tls_in.certificate_verified },
 669   { "tls_cipher",          vtype_stringptr,   &tls_in.cipher },
 670
 671   { "tls_in_bits",         vtype_int,         &tls_in.bits },
 672   { "tls_in_certificate_verified", vtype_int, &tls_in.certificate_verified },
 673   { "tls_in_cipher",       vtype_stringptr,   &tls_in.cipher },
 674   { "tls_in_ourcert",      vtype_cert,        &tls_in.ourcert },
 675   { "tls_in_peercert",     vtype_cert,        &tls_in.peercert },
 676   { "tls_in_peerdn",       vtype_stringptr,   &tls_in.peerdn },
 677 #if defined(SUPPORT_TLS) && !defined(USE_GNUTLS)
 678   { "tls_in_sni",          vtype_stringptr,   &tls_in.sni },
 679 #endif
 680   { "tls_out_bits",        vtype_int,         &tls_out.bits },
 681   { "tls_out_certificate_verified", vtype_int,&tls_out.certificate_verified },
 682   { "tls_out_cipher",      vtype_stringptr,   &tls_out.cipher },
 683   { "tls_out_ourcert",     vtype_cert,        &tls_out.ourcert },
 684   { "tls_out_peercert",    vtype_cert,        &tls_out.peercert },
 685   { "tls_out_peerdn",      vtype_stringptr,   &tls_out.peerdn },
 686 #if defined(SUPPORT_TLS) && !defined(USE_GNUTLS)
 687   { "tls_out_sni",         vtype_stringptr,   &tls_out.sni },
 688 #endif
 689
 690   { "tls_peerdn",          vtype_stringptr,   &tls_in.peerdn }, /* mind the alphabetical order! */
 691 #if defined(SUPPORT_TLS) && !defined(USE_GNUTLS)
 692   { "tls_sni",             vtype_stringptr,   &tls_in.sni },    /* mind the alphabetical order! */
 693 #endif
 694
 695   { "tod_bsdinbox",        vtype_todbsdin,    NULL },
 696   { "tod_epoch",           vtype_tode,        NULL },
 697   { "tod_epoch_l",         vtype_todel,       NULL },
 698   { "tod_full",            vtype_todf,        NULL },
 699   { "tod_log",             vtype_todl,        NULL },
 700   { "tod_logfile",         vtype_todlf,       NULL },
 701   { "tod_zone",            vtype_todzone,     NULL },
 702   { "tod_zulu",            vtype_todzulu,     NULL },
 703 #ifdef EXPERIMENTAL_TPDA
 704   { "tpda_defer_errno",     vtype_int,         &tpda_defer_errno },
 705   { "tpda_defer_errstr",    vtype_stringptr,   &tpda_defer_errstr },
 706   { "tpda_delivery_confirmation", vtype_stringptr,   &tpda_delivery_confirmation },
 707   { "tpda_delivery_domain", vtype_stringptr,   &tpda_delivery_domain },
 708   { "tpda_delivery_fqdn",   vtype_stringptr,   &tpda_delivery_fqdn },
 709   { "tpda_delivery_ip",     vtype_stringptr,   &tpda_delivery_ip },
 710   { "tpda_delivery_local_part",vtype_stringptr,&tpda_delivery_local_part },
 711   { "tpda_delivery_port",   vtype_int,         &tpda_delivery_port },
 712 #endif
 713   { "transport_name",      vtype_stringptr,   &transport_name },
 714   { "value",               vtype_stringptr,   &lookup_value },
 715   { "version_number",      vtype_stringptr,   &version_string },
 716   { "warn_message_delay",  vtype_stringptr,   &warnmsg_delay },
 717   { "warn_message_recipient",vtype_stringptr, &warnmsg_recipients },
 718   { "warn_message_recipients",vtype_stringptr,&warnmsg_recipients },
 719   { "warnmsg_delay",       vtype_stringptr,   &warnmsg_delay },
 720   { "warnmsg_recipient",   vtype_stringptr,   &warnmsg_recipients },
 721   { "warnmsg_recipients",  vtype_stringptr,   &warnmsg_recipients }
 722 };
 723
 724 static int var_table_size = sizeof(var_table)/sizeof(var_entry);
 725 static uschar var_buffer[256];
 726 static BOOL malformed_header;
 727
 728 /* For textual hashes */
 729
 730 static const char *hashcodes = "abcdefghijklmnopqrtsuvwxyz"
 731                                "ABCDEFGHIJKLMNOPQRSTUVWXYZ"
 732                                "0123456789";
 733
 734 enum { HMAC_MD5, HMAC_SHA1 };
 735
 736 /* For numeric hashes */
 737
 738 static unsigned int prime[] = {
 739   2,   3,   5,   7,  11,  13,  17,  19,  23,  29,
 740  31,  37,  41,  43,  47,  53,  59,  61,  67,  71,
 741  73,  79,  83,  89,  97, 101, 103, 107, 109, 113};
 742
 743 /* For printing modes in symbolic form */
 744
 745 static uschar *mtable_normal[] =
 746   { US"---", US"--x", US"-w-", US"-wx", US"r--", US"r-x", US"rw-", US"rwx" };
 747
 748 static uschar *mtable_setid[] =
 749   { US"--S", US"--s", US"-wS", US"-ws", US"r-S", US"r-s", US"rwS", US"rws" };
 750
 751 static uschar *mtable_sticky[] =
 752   { US"--T", US"--t", US"-wT", US"-wt", US"r-T", US"r-t", US"rwT", US"rwt" };
 753
 754
 755
 756 /*************************************************
 757 *           Tables for UTF-8 support             *
 758 *************************************************/
 759
 760 /* Table of the number of extra characters, indexed by the first character
 761 masked with 0x3f. The highest number for a valid UTF-8 character is in fact
 762 0x3d. */
 763
 764 static uschar utf8_table1[] = {
 765   1,1,1,1,1,1,1,1,1,1,1,1,1,1,1,1,
 766   1,1,1,1,1,1,1,1,1,1,1,1,1,1,1,1,
 767   2,2,2,2,2,2,2,2,2,2,2,2,2,2,2,2,
 768   3,3,3,3,3,3,3,3,4,4,4,4,5,5,5,5 };
 769
 770 /* These are the masks for the data bits in the first byte of a character,
 771 indexed by the number of additional bytes. */
 772
 773 static int utf8_table2[] = { 0xff, 0x1f, 0x0f, 0x07, 0x03, 0x01};
 774
 775 /* Get the next UTF-8 character, advancing the pointer. */
 776
 777 #define GETUTF8INC(c, ptr) \
 778   c = *ptr++; \
 779   if ((c & 0xc0) == 0xc0) \
 780     { \
 781     int a = utf8_table1[c & 0x3f];  /* Number of additional bytes */ \
 782     int s = 6*a; \
 783     c = (c & utf8_table2[a]) << s; \
 784     while (a-- > 0) \
 785       { \
 786       s -= 6; \
 787       c |= (*ptr++ & 0x3f) << s; \
 788       } \
 789     }
 790
 791
 792 /*************************************************
 793 *           Binary chop search on a table        *
 794 *************************************************/
 795
 796 /* This is used for matching expansion items and operators.
 797
 798 Arguments:
 799   name        the name that is being sought
 800   table       the table to search
 801   table_size  the number of items in the table
 802
 803 Returns:      the offset in the table, or -1
 804 */
 805
 806 static int
 807 chop_match(uschar *name, uschar **table, int table_size)
 808 {
 809 uschar **bot = table;
 810 uschar **top = table + table_size;
 811
 812 while (top > bot)
 813   {
 814   uschar **mid = bot + (top - bot)/2;
 815   int c = Ustrcmp(name, *mid);
 816   if (c == 0) return mid - table;
 817   if (c > 0) bot = mid + 1; else top = mid;
 818   }
 819
 820 return -1;
 821 }
 822
 823
 824
 825 /*************************************************
 826 *          Check a condition string              *
 827 *************************************************/
 828
 829 /* This function is called to expand a string, and test the result for a "true"
 830 or "false" value. Failure of the expansion yields FALSE; logged unless it was a
 831 forced fail or lookup defer.
 832
 833 We used to release all store used, but this is not not safe due
 834 to ${dlfunc } and ${acl }.  In any case expand_string_internal()
 835 is reasonably careful to release what it can.
 836
 837 The actual false-value tests should be replicated for ECOND_BOOL_LAX.
 838
 839 Arguments:
 840   condition     the condition string
 841   m1            text to be incorporated in panic error
 842   m2            ditto
 843
 844 Returns:        TRUE if condition is met, FALSE if not
 845 */
 846
 847 BOOL
 848 expand_check_condition(uschar *condition, uschar *m1, uschar *m2)
 849 {
 850 int rc;
 851 uschar *ss = expand_string(condition);
 852 if (ss == NULL)
 853   {
 854   if (!expand_string_forcedfail && !search_find_defer)
 855     log_write(0, LOG_MAIN|LOG_PANIC, "failed to expand condition \"%s\" "
 856       "for %s %s: %s", condition, m1, m2, expand_string_message);
 857   return FALSE;
 858   }
 859 rc = ss[0] != 0 && Ustrcmp(ss, "0") != 0 && strcmpic(ss, US"no") != 0 &&
 860   strcmpic(ss, US"false") != 0;
 861 return rc;
 862 }
 863
 864
 865
 866
 867 /*************************************************
 868 *        Pseudo-random number generation         *
 869 *************************************************/
 870
 871 /* Pseudo-random number generation.  The result is not "expected" to be
 872 cryptographically strong but not so weak that someone will shoot themselves
 873 in the foot using it as a nonce in some email header scheme or whatever
 874 weirdness they'll twist this into.  The result should ideally handle fork().
 875
 876 However, if we're stuck unable to provide this, then we'll fall back to
 877 appallingly bad randomness.
 878
 879 If SUPPORT_TLS is defined then this will not be used except as an emergency
 880 fallback.
 881
 882 Arguments:
 883   max       range maximum
 884 Returns     a random number in range [0, max-1]
 885 */
 886
 887 #ifdef SUPPORT_TLS
 888 # define vaguely_random_number vaguely_random_number_fallback
 889 #endif
 890 int
 891 vaguely_random_number(int max)
 892 {
 893 #ifdef SUPPORT_TLS
 894 # undef vaguely_random_number
 895 #endif
 896   static pid_t pid = 0;
 897   pid_t p2;
 898 #if defined(HAVE_SRANDOM) && !defined(HAVE_SRANDOMDEV)
 899   struct timeval tv;
 900 #endif
 901
 902   p2 = getpid();
 903   if (p2 != pid)
 904     {
 905     if (pid != 0)
 906       {
 907
 908 #ifdef HAVE_ARC4RANDOM
 909       /* cryptographically strong randomness, common on *BSD platforms, not
 910       so much elsewhere.  Alas. */
 911       arc4random_stir();
 912 #elif defined(HAVE_SRANDOM) || defined(HAVE_SRANDOMDEV)
 913 #ifdef HAVE_SRANDOMDEV
 914       /* uses random(4) for seeding */
 915       srandomdev();
 916 #else
 917       gettimeofday(&tv, NULL);
 918       srandom(tv.tv_sec | tv.tv_usec | getpid());
 919 #endif
 920 #else
 921       /* Poor randomness and no seeding here */
 922 #endif
 923
 924       }
 925     pid = p2;
 926     }
 927
 928 #ifdef HAVE_ARC4RANDOM
 929   return arc4random() % max;
 930 #elif defined(HAVE_SRANDOM) || defined(HAVE_SRANDOMDEV)
 931   return random() % max;
 932 #else
 933   /* This one returns a 16-bit number, definitely not crypto-strong */
 934   return random_number(max);
 935 #endif
 936 }
 937
 938
 939
 940
 941 /*************************************************
 942 *             Pick out a name from a string      *
 943 *************************************************/
 944
 945 /* If the name is too long, it is silently truncated.
 946
 947 Arguments:
 948   name      points to a buffer into which to put the name
 949   max       is the length of the buffer
 950   s         points to the first alphabetic character of the name
 951   extras    chars other than alphanumerics to permit
 952
 953 Returns:    pointer to the first character after the name
 954
 955 Note: The test for *s != 0 in the while loop is necessary because
 956 Ustrchr() yields non-NULL if the character is zero (which is not something
 957 I expected). */
 958
 959 static uschar *
 960 read_name(uschar *name, int max, uschar *s, uschar *extras)
 961 {
 962 int ptr = 0;
 963 while (*s != 0 && (isalnum(*s) || Ustrchr(extras, *s) != NULL))
 964   {
 965   if (ptr < max-1) name[ptr++] = *s;
 966   s++;
 967   }
 968 name[ptr] = 0;
 969 return s;
 970 }
 971
 972
 973
 974 /*************************************************
 975 *     Pick out the rest of a header name         *
 976 *************************************************/
 977
 978 /* A variable name starting $header_ (or just $h_ for those who like
 979 abbreviations) might not be the complete header name because headers can
 980 contain any printing characters in their names, except ':'. This function is
 981 called to read the rest of the name, chop h[eader]_ off the front, and put ':'
 982 on the end, if the name was terminated by white space.
 983
 984 Arguments:
 985   name      points to a buffer in which the name read so far exists
 986   max       is the length of the buffer
 987   s         points to the first character after the name so far, i.e. the
 988             first non-alphameric character after $header_xxxxx
 989
 990 Returns:    a pointer to the first character after the header name
 991 */
 992
 993 static uschar *
 994 read_header_name(uschar *name, int max, uschar *s)
 995 {
 996 int prelen = Ustrchr(name, '_') - name + 1;
 997 int ptr = Ustrlen(name) - prelen;
 998 if (ptr > 0) memmove(name, name+prelen, ptr);
 999 while (mac_isgraph(*s) && *s != ':')
1000   {
1001   if (ptr < max-1) name[ptr++] = *s;
1002   s++;
1003   }
1004 if (*s == ':') s++;
1005 name[ptr++] = ':';
1006 name[ptr] = 0;
1007 return s;
1008 }
1009
1010
1011
1012 /*************************************************
1013 *           Pick out a number from a string      *
1014 *************************************************/
1015
1016 /* Arguments:
1017   n     points to an integer into which to put the number
1018   s     points to the first digit of the number
1019
1020 Returns:  a pointer to the character after the last digit
1021 */
1022
1023 static uschar *
1024 read_number(int *n, uschar *s)
1025 {
1026 *n = 0;
1027 while (isdigit(*s)) *n = *n * 10 + (*s++ - '0');
1028 return s;
1029 }
1030
1031
1032
1033 /*************************************************
1034 *        Extract keyed subfield from a string    *
1035 *************************************************/
1036
1037 /* The yield is in dynamic store; NULL means that the key was not found.
1038
1039 Arguments:
1040   key       points to the name of the key
1041   s         points to the string from which to extract the subfield
1042
1043 Returns:    NULL if the subfield was not found, or
1044             a pointer to the subfield's data
1045 */
1046
1047 static uschar *
1048 expand_getkeyed(uschar *key, uschar *s)
1049 {
1050 int length = Ustrlen(key);
1051 while (isspace(*s)) s++;
1052
1053 /* Loop to search for the key */
1054
1055 while (*s != 0)
1056   {
1057   int dkeylength;
1058   uschar *data;
1059   uschar *dkey = s;
1060
1061   while (*s != 0 && *s != '=' && !isspace(*s)) s++;
1062   dkeylength = s - dkey;
1063   while (isspace(*s)) s++;
1064   if (*s == '=') while (isspace((*(++s))));
1065
1066   data = string_dequote(&s);
1067   if (length == dkeylength && strncmpic(key, dkey, length) == 0)
1068     return data;
1069
1070   while (isspace(*s)) s++;
1071   }
1072
1073 return NULL;
1074 }
1075
1076
1077
1078 static var_entry *
1079 find_var_ent(uschar * name)
1080 {
1081 int first = 0;
1082 int last = var_table_size;
1083
1084 while (last > first)
1085   {
1086   int middle = (first + last)/2;
1087   int c = Ustrcmp(name, var_table[middle].name);
1088
1089   if (c > 0) { first = middle + 1; continue; }
1090   if (c < 0) { last = middle; continue; }
1091   return &var_table[middle];
1092   }
1093 return NULL;
1094 }
1095
1096 /*************************************************
1097 *   Extract numbered subfield from string        *
1098 *************************************************/
1099
1100 /* Extracts a numbered field from a string that is divided by tokens - for
1101 example a line from /etc/passwd is divided by colon characters.  First field is
1102 numbered one.  Negative arguments count from the right. Zero returns the whole
1103 string. Returns NULL if there are insufficient tokens in the string
1104
1105 ***WARNING***
1106 Modifies final argument - this is a dynamically generated string, so that's OK.
1107
1108 Arguments:
1109   field       number of field to be extracted,
1110                 first field = 1, whole string = 0, last field = -1
1111   separators  characters that are used to break string into tokens
1112   s           points to the string from which to extract the subfield
1113
1114 Returns:      NULL if the field was not found,
1115               a pointer to the field's data inside s (modified to add 0)
1116 */
1117
1118 static uschar *
1119 expand_gettokened (int field, uschar *separators, uschar *s)
1120 {
1121 int sep = 1;
1122 int count;
1123 uschar *ss = s;
1124 uschar *fieldtext = NULL;
1125
1126 if (field == 0) return s;
1127
1128 /* Break the line up into fields in place; for field > 0 we stop when we have
1129 done the number of fields we want. For field < 0 we continue till the end of
1130 the string, counting the number of fields. */
1131
1132 count = (field > 0)? field : INT_MAX;
1133
1134 while (count-- > 0)
1135   {
1136   size_t len;
1137
1138   /* Previous field was the last one in the string. For a positive field
1139   number, this means there are not enough fields. For a negative field number,
1140   check that there are enough, and scan back to find the one that is wanted. */
1141
1142   if (sep == 0)
1143     {
1144     if (field > 0 || (-field) > (INT_MAX - count - 1)) return NULL;
1145     if ((-field) == (INT_MAX - count - 1)) return s;
1146     while (field++ < 0)
1147       {
1148       ss--;
1149       while (ss[-1] != 0) ss--;
1150       }
1151     fieldtext = ss;
1152     break;
1153     }
1154
1155   /* Previous field was not last in the string; save its start and put a
1156   zero at its end. */
1157
1158   fieldtext = ss;
1159   len = Ustrcspn(ss, separators);
1160   sep = ss[len];
1161   ss[len] = 0;
1162   ss += len + 1;
1163   }
1164
1165 return fieldtext;
1166 }
1167
1168
1169 static uschar *
1170 expand_getlistele(int field, uschar * list)
1171 {
1172 uschar * tlist= list;
1173 int sep= 0;
1174 uschar dummy;
1175
1176 if(field<0)
1177 {
1178   for(field++; string_nextinlist(&tlist, &sep, &dummy, 1); ) field++;
1179   sep= 0;
1180 }
1181 if(field==0) return NULL;
1182 while(--field>0 && (string_nextinlist(&list, &sep, &dummy, 1))) ;
1183 return string_nextinlist(&list, &sep, NULL, 0);
1184 }
1185
1186
1187 /* Certificate fields, by name.  Worry about by-OID later */
1188
1189 #ifdef SUPPORT_TLS
1190 typedef struct
1191 {
1192 uschar * name;
1193 uschar * (*getfn)(void * cert);
1194 } certfield;
1195 static certfield certfields[] =
1196 {                       /* linear search; no special order */
1197   { US"version",        &tls_cert_version },
1198   { US"serial_number",  &tls_cert_serial_number },
1199   { US"subject",        &tls_cert_subject },
1200   { US"notbefore",      &tls_cert_not_before },
1201   { US"notafter",       &tls_cert_not_after },
1202   { US"issuer",         &tls_cert_issuer },
1203   { US"signature",      &tls_cert_signature },
1204   { US"signature_algorithm",    &tls_cert_signature_algorithm },
1205   { US"subject_altname",        &tls_cert_subject_altname },
1206   { US"ocsp_uri",       &tls_cert_ocsp_uri },
1207   { US"crl_uri",        &tls_cert_crl_uri },
1208 };
1209
1210 static uschar *
1211 expand_getcertele(uschar * field, uschar * certvar)
1212 {
1213 var_entry * vp;
1214 certfield * cp;
1215
1216 if (!(vp = find_var_ent(certvar)))
1217   {
1218   expand_string_message =
1219     string_sprintf("no variable named \"%s\"", certvar);
1220   return NULL;          /* Unknown variable name */
1221   }
1222 /* NB this stops us passing certs around in variable.  Might
1223 want to do that in future */
1224 if (vp->type != vtype_cert)
1225   {
1226   expand_string_message =
1227     string_sprintf("\"%s\" is not a certificate", certvar);
1228   return NULL;          /* Unknown variable name */
1229   }
1230 if (!*(void **)vp->value)
1231   return NULL;
1232
1233 if (*field >= '0' && *field <= '9')
1234   return tls_cert_ext_by_oid(*(void **)vp->value, field, 0);
1235
1236 for(cp = certfields;
1237     cp < certfields + nelements(certfields);
1238     cp++)
1239   if (Ustrcmp(cp->name, field) == 0)
1240     return (*cp->getfn)( *(void **)vp->value );
1241
1242 expand_string_message =
1243   string_sprintf("bad field selector \"%s\" for certextract", field);
1244 return NULL;
1245 }
1246 #endif  /*SUPPORT_TLS*/
1247
1248 /*************************************************
1249 *        Extract a substring from a string       *
1250 *************************************************/
1251
1252 /* Perform the ${substr or ${length expansion operations.
1253
1254 Arguments:
1255   subject     the input string
1256   value1      the offset from the start of the input string to the start of
1257                 the output string; if negative, count from the right.
1258   value2      the length of the output string, or negative (-1) for unset
1259                 if value1 is positive, unset means "all after"
1260                 if value1 is negative, unset means "all before"
1261   len         set to the length of the returned string
1262
1263 Returns:      pointer to the output string, or NULL if there is an error
1264 */
1265
1266 static uschar *
1267 extract_substr(uschar *subject, int value1, int value2, int *len)
1268 {
1269 int sublen = Ustrlen(subject);
1270
1271 if (value1 < 0)    /* count from right */
1272   {
1273   value1 += sublen;
1274
1275   /* If the position is before the start, skip to the start, and adjust the
1276   length. If the length ends up negative, the substring is null because nothing
1277   can precede. This falls out naturally when the length is unset, meaning "all
1278   to the left". */
1279
1280   if (value1 < 0)
1281     {
1282     value2 += value1;
1283     if (value2 < 0) value2 = 0;
1284     value1 = 0;
1285     }
1286
1287   /* Otherwise an unset length => characters before value1 */
1288
1289   else if (value2 < 0)
1290     {
1291     value2 = value1;
1292     value1 = 0;
1293     }
1294   }
1295
1296 /* For a non-negative offset, if the starting position is past the end of the
1297 string, the result will be the null string. Otherwise, an unset length means
1298 "rest"; just set it to the maximum - it will be cut down below if necessary. */
1299
1300 else
1301   {
1302   if (value1 > sublen)
1303     {
1304     value1 = sublen;
1305     value2 = 0;
1306     }
1307   else if (value2 < 0) value2 = sublen;
1308   }
1309
1310 /* Cut the length down to the maximum possible for the offset value, and get
1311 the required characters. */
1312
1313 if (value1 + value2 > sublen) value2 = sublen - value1;
1314 *len = value2;
1315 return subject + value1;
1316 }
1317
1318
1319
1320
1321 /*************************************************
1322 *            Old-style hash of a string          *
1323 *************************************************/
1324
1325 /* Perform the ${hash expansion operation.
1326
1327 Arguments:
1328   subject     the input string (an expanded substring)
1329   value1      the length of the output string; if greater or equal to the
1330                 length of the input string, the input string is returned
1331   value2      the number of hash characters to use, or 26 if negative
1332   len         set to the length of the returned string
1333
1334 Returns:      pointer to the output string, or NULL if there is an error
1335 */
1336
1337 static uschar *
1338 compute_hash(uschar *subject, int value1, int value2, int *len)
1339 {
1340 int sublen = Ustrlen(subject);
1341
1342 if (value2 < 0) value2 = 26;
1343 else if (value2 > Ustrlen(hashcodes))
1344   {
1345   expand_string_message =
1346     string_sprintf("hash count \"%d\" too big", value2);
1347   return NULL;
1348   }
1349
1350 /* Calculate the hash text. We know it is shorter than the original string, so
1351 can safely place it in subject[] (we know that subject is always itself an
1352 expanded substring). */
1353
1354 if (value1 < sublen)
1355   {
1356   int c;
1357   int i = 0;
1358   int j = value1;
1359   while ((c = (subject[j])) != 0)
1360     {
1361     int shift = (c + j++) & 7;
1362     subject[i] ^= (c << shift) | (c >> (8-shift));
1363     if (++i >= value1) i = 0;
1364     }
1365   for (i = 0; i < value1; i++)
1366     subject[i] = hashcodes[(subject[i]) % value2];
1367   }
1368 else value1 = sublen;
1369
1370 *len = value1;
1371 return subject;
1372 }
1373
1374
1375
1376
1377 /*************************************************
1378 *             Numeric hash of a string           *
1379 *************************************************/
1380
1381 /* Perform the ${nhash expansion operation. The first characters of the
1382 string are treated as most important, and get the highest prime numbers.
1383
1384 Arguments:
1385   subject     the input string
1386   value1      the maximum value of the first part of the result
1387   value2      the maximum value of the second part of the result,
1388                 or negative to produce only a one-part result
1389   len         set to the length of the returned string
1390
1391 Returns:  pointer to the output string, or NULL if there is an error.
1392 */
1393
1394 static uschar *
1395 compute_nhash (uschar *subject, int value1, int value2, int *len)
1396 {
1397 uschar *s = subject;
1398 int i = 0;
1399 unsigned long int total = 0; /* no overflow */
1400
1401 while (*s != 0)
1402   {
1403   if (i == 0) i = sizeof(prime)/sizeof(int) - 1;
1404   total += prime[i--] * (unsigned int)(*s++);
1405   }
1406
1407 /* If value2 is unset, just compute one number */
1408
1409 if (value2 < 0)
1410   {
1411   s = string_sprintf("%d", total % value1);
1412   }
1413
1414 /* Otherwise do a div/mod hash */
1415
1416 else
1417   {
1418   total = total % (value1 * value2);
1419   s = string_sprintf("%d/%d", total/value2, total % value2);
1420   }
1421
1422 *len = Ustrlen(s);
1423 return s;
1424 }
1425
1426
1427
1428
1429
1430 /*************************************************
1431 *     Find the value of a header or headers      *
1432 *************************************************/
1433
1434 /* Multiple instances of the same header get concatenated, and this function
1435 can also return a concatenation of all the header lines. When concatenating
1436 specific headers that contain lists of addresses, a comma is inserted between
1437 them. Otherwise we use a straight concatenation. Because some messages can have
1438 pathologically large number of lines, there is a limit on the length that is
1439 returned. Also, to avoid massive store use which would result from using
1440 string_cat() as it copies and extends strings, we do a preliminary pass to find
1441 out exactly how much store will be needed. On "normal" messages this will be
1442 pretty trivial.
1443
1444 Arguments:
1445   name          the name of the header, without the leading $header_ or $h_,
1446                 or NULL if a concatenation of all headers is required
1447   exists_only   TRUE if called from a def: test; don't need to build a string;
1448                 just return a string that is not "" and not "0" if the header
1449                 exists
1450   newsize       return the size of memory block that was obtained; may be NULL
1451                 if exists_only is TRUE
1452   want_raw      TRUE if called for $rh_ or $rheader_ variables; no processing,
1453                 other than concatenating, will be done on the header. Also used
1454                 for $message_headers_raw.
1455   charset       name of charset to translate MIME words to; used only if
1456                 want_raw is false; if NULL, no translation is done (this is
1457                 used for $bh_ and $bheader_)
1458
1459 Returns:        NULL if the header does not exist, else a pointer to a new
1460                 store block
1461 */
1462
1463 static uschar *
1464 find_header(uschar *name, BOOL exists_only, int *newsize, BOOL want_raw,
1465   uschar *charset)
1466 {
1467 BOOL found = name == NULL;
1468 int comma = 0;
1469 int len = found? 0 : Ustrlen(name);
1470 int i;
1471 uschar *yield = NULL;
1472 uschar *ptr = NULL;
1473
1474 /* Loop for two passes - saves code repetition */
1475
1476 for (i = 0; i < 2; i++)
1477   {
1478   int size = 0;
1479   header_line *h;
1480
1481   for (h = header_list; size < header_insert_maxlen && h != NULL; h = h->next)
1482     {
1483     if (h->type != htype_old && h->text != NULL)  /* NULL => Received: placeholder */
1484       {
1485       if (name == NULL || (len <= h->slen && strncmpic(name, h->text, len) == 0))
1486         {
1487         int ilen;
1488         uschar *t;
1489
1490         if (exists_only) return US"1";      /* don't need actual string */
1491         found = TRUE;
1492         t = h->text + len;                  /* text to insert */
1493         if (!want_raw)                      /* unless wanted raw, */
1494           while (isspace(*t)) t++;          /* remove leading white space */
1495         ilen = h->slen - (t - h->text);     /* length to insert */
1496
1497         /* Unless wanted raw, remove trailing whitespace, including the
1498         newline. */
1499
1500         if (!want_raw)
1501           while (ilen > 0 && isspace(t[ilen-1])) ilen--;
1502
1503         /* Set comma = 1 if handling a single header and it's one of those
1504         that contains an address list, except when asked for raw headers. Only
1505         need to do this once. */
1506
1507         if (!want_raw && name != NULL && comma == 0 &&
1508             Ustrchr("BCFRST", h->type) != NULL)
1509           comma = 1;
1510
1511         /* First pass - compute total store needed; second pass - compute
1512         total store used, including this header. */
1513
1514         size += ilen + comma + 1;  /* +1 for the newline */
1515
1516         /* Second pass - concatentate the data, up to a maximum. Note that
1517         the loop stops when size hits the limit. */
1518
1519         if (i != 0)
1520           {
1521           if (size > header_insert_maxlen)
1522             {
1523             ilen -= size - header_insert_maxlen - 1;
1524             comma = 0;
1525             }
1526           Ustrncpy(ptr, t, ilen);
1527           ptr += ilen;
1528
1529           /* For a non-raw header, put in the comma if needed, then add
1530           back the newline we removed above, provided there was some text in
1531           the header. */
1532
1533           if (!want_raw && ilen > 0)
1534             {
1535             if (comma != 0) *ptr++ = ',';
1536             *ptr++ = '\n';
1537             }
1538           }
1539         }
1540       }
1541     }
1542
1543   /* At end of first pass, return NULL if no header found. Then truncate size
1544   if necessary, and get the buffer to hold the data, returning the buffer size.
1545   */
1546
1547   if (i == 0)
1548     {
1549     if (!found) return NULL;
1550     if (size > header_insert_maxlen) size = header_insert_maxlen;
1551     *newsize = size + 1;
1552     ptr = yield = store_get(*newsize);
1553     }
1554   }
1555
1556 /* That's all we do for raw header expansion. */
1557
1558 if (want_raw)
1559   {
1560   *ptr = 0;
1561   }
1562
1563 /* Otherwise, remove a final newline and a redundant added comma. Then we do
1564 RFC 2047 decoding, translating the charset if requested. The rfc2047_decode2()
1565 function can return an error with decoded data if the charset translation
1566 fails. If decoding fails, it returns NULL. */
1567
1568 else
1569   {
1570   uschar *decoded, *error;
1571   if (ptr > yield && ptr[-1] == '\n') ptr--;
1572   if (ptr > yield && comma != 0 && ptr[-1] == ',') ptr--;
1573   *ptr = 0;
1574   decoded = rfc2047_decode2(yield, check_rfc2047_length, charset, '?', NULL,
1575     newsize, &error);
1576   if (error != NULL)
1577     {
1578     DEBUG(D_any) debug_printf("*** error in RFC 2047 decoding: %s\n"
1579       "    input was: %s\n", error, yield);
1580     }
1581   if (decoded != NULL) yield = decoded;
1582   }
1583
1584 return yield;
1585 }
1586
1587
1588
1589
1590 /*************************************************
1591 *               Return list of recipients        *
1592 *************************************************/
1593 /* A recipients list is available only during system message filtering,
1594 during ACL processing after DATA, and while expanding pipe commands
1595 generated from a system filter, but not elsewhere. */
1596
1597 static uschar *
1598 fn_recipients(void)
1599 {
1600 if (!enable_dollar_recipients) return NULL; else
1601   {
1602   int size = 128;
1603   int ptr = 0;
1604   int i;
1605   uschar * s = store_get(size);
1606   for (i = 0; i < recipients_count; i++)
1607     {
1608     if (i != 0) s = string_cat(s, &size, &ptr, US", ", 2);
1609     s = string_cat(s, &size, &ptr, recipients_list[i].address,
1610       Ustrlen(recipients_list[i].address));
1611     }
1612   s[ptr] = 0;     /* string_cat() leaves room */
1613   return s;
1614   }
1615 }
1616
1617
1618 /*************************************************
1619 *               Find value of a variable         *
1620 *************************************************/
1621
1622 /* The table of variables is kept in alphabetic order, so we can search it
1623 using a binary chop. The "choplen" variable is nothing to do with the binary
1624 chop.
1625
1626 Arguments:
1627   name          the name of the variable being sought
1628   exists_only   TRUE if this is a def: test; passed on to find_header()
1629   skipping      TRUE => skip any processing evaluation; this is not the same as
1630                   exists_only because def: may test for values that are first
1631                   evaluated here
1632   newsize       pointer to an int which is initially zero; if the answer is in
1633                 a new memory buffer, *newsize is set to its size
1634
1635 Returns:        NULL if the variable does not exist, or
1636                 a pointer to the variable's contents, or
1637                 something non-NULL if exists_only is TRUE
1638 */
1639
1640 static uschar *
1641 find_variable(uschar *name, BOOL exists_only, BOOL skipping, int *newsize)
1642 {
1643 var_entry * vp;
1644 uschar *s, *domain;
1645 uschar **ss;
1646 void * val;
1647
1648 /* Handle ACL variables, whose names are of the form acl_cxxx or acl_mxxx.
1649 Originally, xxx had to be a number in the range 0-9 (later 0-19), but from
1650 release 4.64 onwards arbitrary names are permitted, as long as the first 5
1651 characters are acl_c or acl_m and the sixth is either a digit or an underscore
1652 (this gave backwards compatibility at the changeover). There may be built-in
1653 variables whose names start acl_ but they should never start in this way. This
1654 slightly messy specification is a consequence of the history, needless to say.
1655
1656 If an ACL variable does not exist, treat it as empty, unless strict_acl_vars is
1657 set, in which case give an error. */
1658
1659 if ((Ustrncmp(name, "acl_c", 5) == 0 || Ustrncmp(name, "acl_m", 5) == 0) &&
1660      !isalpha(name[5]))
1661   {
1662   tree_node *node =
1663     tree_search((name[4] == 'c')? acl_var_c : acl_var_m, name + 4);
1664   return (node == NULL)? (strict_acl_vars? NULL : US"") : node->data.ptr;
1665   }
1666
1667 /* Handle $auth<n> variables. */
1668
1669 if (Ustrncmp(name, "auth", 4) == 0)
1670   {
1671   uschar *endptr;
1672   int n = Ustrtoul(name + 4, &endptr, 10);
1673   if (*endptr == 0 && n != 0 && n <= AUTH_VARS)
1674     return (auth_vars[n-1] == NULL)? US"" : auth_vars[n-1];
1675   }
1676
1677 /* For all other variables, search the table */
1678
1679 if (!(vp = find_var_ent(name)))
1680   return NULL;          /* Unknown variable name */
1681
1682 /* Found an existing variable. If in skipping state, the value isn't needed,
1683 and we want to avoid processing (such as looking up the host name). */
1684
1685 if (skipping)
1686   return US"";
1687
1688 val = vp->value;
1689 switch (vp->type)
1690   {
1691   case vtype_filter_int:
1692   if (!filter_running) return NULL;
1693   /* Fall through */
1694   /* VVVVVVVVVVVV */
1695   case vtype_int:
1696   sprintf(CS var_buffer, "%d", *(int *)(val)); /* Integer */
1697   return var_buffer;
1698
1699   case vtype_ino:
1700   sprintf(CS var_buffer, "%ld", (long int)(*(ino_t *)(val))); /* Inode */
1701   return var_buffer;
1702
1703   case vtype_gid:
1704   sprintf(CS var_buffer, "%ld", (long int)(*(gid_t *)(val))); /* gid */
1705   return var_buffer;
1706
1707   case vtype_uid:
1708   sprintf(CS var_buffer, "%ld", (long int)(*(uid_t *)(val))); /* uid */
1709   return var_buffer;
1710
1711   case vtype_bool:
1712   sprintf(CS var_buffer, "%s", *(BOOL *)(val) ? "yes" : "no"); /* bool */
1713   return var_buffer;
1714
1715   case vtype_stringptr:                      /* Pointer to string */
1716   s = *((uschar **)(val));
1717   return (s == NULL)? US"" : s;
1718
1719   case vtype_pid:
1720   sprintf(CS var_buffer, "%d", (int)getpid()); /* pid */
1721   return var_buffer;
1722
1723   case vtype_load_avg:
1724   sprintf(CS var_buffer, "%d", OS_GETLOADAVG()); /* load_average */
1725   return var_buffer;
1726
1727   case vtype_host_lookup:                    /* Lookup if not done so */
1728   if (sender_host_name == NULL && sender_host_address != NULL &&
1729       !host_lookup_failed && host_name_lookup() == OK)
1730     host_build_sender_fullhost();
1731   return (sender_host_name == NULL)? US"" : sender_host_name;
1732
1733   case vtype_localpart:                      /* Get local part from address */
1734   s = *((uschar **)(val));
1735   if (s == NULL) return US"";
1736   domain = Ustrrchr(s, '@');
1737   if (domain == NULL) return s;
1738   if (domain - s > sizeof(var_buffer) - 1)
1739     log_write(0, LOG_MAIN|LOG_PANIC_DIE, "local part longer than " SIZE_T_FMT
1740         " in string expansion", sizeof(var_buffer));
1741   Ustrncpy(var_buffer, s, domain - s);
1742   var_buffer[domain - s] = 0;
1743   return var_buffer;
1744
1745   case vtype_domain:                         /* Get domain from address */
1746   s = *((uschar **)(val));
1747   if (s == NULL) return US"";
1748   domain = Ustrrchr(s, '@');
1749   return (domain == NULL)? US"" : domain + 1;
1750
1751   case vtype_msgheaders:
1752   return find_header(NULL, exists_only, newsize, FALSE, NULL);
1753
1754   case vtype_msgheaders_raw:
1755   return find_header(NULL, exists_only, newsize, TRUE, NULL);
1756
1757   case vtype_msgbody:                        /* Pointer to msgbody string */
1758   case vtype_msgbody_end:                    /* Ditto, the end of the msg */
1759   ss = (uschar **)(val);
1760   if (*ss == NULL && deliver_datafile >= 0)  /* Read body when needed */
1761     {
1762     uschar *body;
1763     off_t start_offset = SPOOL_DATA_START_OFFSET;
1764     int len = message_body_visible;
1765     if (len > message_size) len = message_size;
1766     *ss = body = store_malloc(len+1);
1767     body[0] = 0;
1768     if (vp->type == vtype_msgbody_end)
1769       {
1770       struct stat statbuf;
1771       if (fstat(deliver_datafile, &statbuf) == 0)
1772         {
1773         start_offset = statbuf.st_size - len;
1774         if (start_offset < SPOOL_DATA_START_OFFSET)
1775           start_offset = SPOOL_DATA_START_OFFSET;
1776         }
1777       }
1778     lseek(deliver_datafile, start_offset, SEEK_SET);
1779     len = read(deliver_datafile, body, len);
1780     if (len > 0)
1781       {
1782       body[len] = 0;
1783       if (message_body_newlines)   /* Separate loops for efficiency */
1784         {
1785         while (len > 0)
1786           { if (body[--len] == 0) body[len] = ' '; }
1787         }
1788       else
1789         {
1790         while (len > 0)
1791           { if (body[--len] == '\n' || body[len] == 0) body[len] = ' '; }
1792         }
1793       }
1794     }
1795   return (*ss == NULL)? US"" : *ss;
1796
1797   case vtype_todbsdin:                       /* BSD inbox time of day */
1798   return tod_stamp(tod_bsdin);
1799
1800   case vtype_tode:                           /* Unix epoch time of day */
1801   return tod_stamp(tod_epoch);
1802
1803   case vtype_todel:                          /* Unix epoch/usec time of day */
1804   return tod_stamp(tod_epoch_l);
1805
1806   case vtype_todf:                           /* Full time of day */
1807   return tod_stamp(tod_full);
1808
1809   case vtype_todl:                           /* Log format time of day */
1810   return tod_stamp(tod_log_bare);            /* (without timezone) */
1811
1812   case vtype_todzone:                        /* Time zone offset only */
1813   return tod_stamp(tod_zone);
1814
1815   case vtype_todzulu:                        /* Zulu time */
1816   return tod_stamp(tod_zulu);
1817
1818   case vtype_todlf:                          /* Log file datestamp tod */
1819   return tod_stamp(tod_log_datestamp_daily);
1820
1821   case vtype_reply:                          /* Get reply address */
1822   s = find_header(US"reply-to:", exists_only, newsize, TRUE,
1823     headers_charset);
1824   if (s != NULL) while (isspace(*s)) s++;
1825   if (s == NULL || *s == 0)
1826     {
1827     *newsize = 0;                            /* For the *s==0 case */
1828     s = find_header(US"from:", exists_only, newsize, TRUE, headers_charset);
1829     }
1830   if (s != NULL)
1831     {
1832     uschar *t;
1833     while (isspace(*s)) s++;
1834     for (t = s; *t != 0; t++) if (*t == '\n') *t = ' ';
1835     while (t > s && isspace(t[-1])) t--;
1836     *t = 0;
1837     }
1838   return (s == NULL)? US"" : s;
1839
1840   case vtype_string_func:
1841     {
1842     uschar * (*fn)() = val;
1843     return fn();
1844     }
1845
1846   case vtype_pspace:
1847     {
1848     int inodes;
1849     sprintf(CS var_buffer, "%d",
1850       receive_statvfs(val == (void *)TRUE, &inodes));
1851     }
1852   return var_buffer;
1853
1854   case vtype_pinodes:
1855     {
1856     int inodes;
1857     (void) receive_statvfs(val == (void *)TRUE, &inodes);
1858     sprintf(CS var_buffer, "%d", inodes);
1859     }
1860   return var_buffer;
1861
1862   case vtype_cert:
1863   return *(void **)val ? US"<cert>" : US"";
1864
1865   #ifndef DISABLE_DKIM
1866   case vtype_dkim:
1867   return dkim_exim_expand_query((int)(long)val);
1868   #endif
1869
1870   }
1871 }
1872
1873
1874
1875
1876 void
1877 modify_variable(uschar *name, void * value)
1878 {
1879 var_entry * vp;
1880 if ((vp = find_var_ent(name))) vp->value = value;
1881 return;          /* Unknown variable name, fail silently */
1882 }
1883
1884
1885
1886
1887
1888 /*************************************************
1889 *           Read and expand substrings           *
1890 *************************************************/
1891
1892 /* This function is called to read and expand argument substrings for various
1893 expansion items. Some have a minimum requirement that is less than the maximum;
1894 in these cases, the first non-present one is set to NULL.
1895
1896 Arguments:
1897   sub        points to vector of pointers to set
1898   n          maximum number of substrings
1899   m          minimum required
1900   sptr       points to current string pointer
1901   skipping   the skipping flag
1902   check_end  if TRUE, check for final '}'
1903   name       name of item, for error message
1904   resetok    if not NULL, pointer to flag - write FALSE if unsafe to reset
1905              the store.
1906
1907 Returns:     0 OK; string pointer updated
1908              1 curly bracketing error (too few arguments)
1909              2 too many arguments (only if check_end is set); message set
1910              3 other error (expansion failure)
1911 */
1912
1913 static int
1914 read_subs(uschar **sub, int n, int m, uschar **sptr, BOOL skipping,
1915   BOOL check_end, uschar *name, BOOL *resetok)
1916 {
1917 int i;
1918 uschar *s = *sptr;
1919
1920 while (isspace(*s)) s++;
1921 for (i = 0; i < n; i++)
1922   {
1923   if (*s != '{')
1924     {
1925     if (i < m) return 1;
1926     sub[i] = NULL;
1927     break;
1928     }
1929   sub[i] = expand_string_internal(s+1, TRUE, &s, skipping, TRUE, resetok);
1930   if (sub[i] == NULL) return 3;
1931   if (*s++ != '}') return 1;
1932   while (isspace(*s)) s++;
1933   }
1934 if (check_end && *s++ != '}')
1935   {
1936   if (s[-1] == '{')
1937     {
1938     expand_string_message = string_sprintf("Too many arguments for \"%s\" "
1939       "(max is %d)", name, n);
1940     return 2;
1941     }
1942   return 1;
1943   }
1944
1945 *sptr = s;
1946 return 0;
1947 }
1948
1949
1950
1951
1952 /*************************************************
1953 *     Elaborate message for bad variable         *
1954 *************************************************/
1955
1956 /* For the "unknown variable" message, take a look at the variable's name, and
1957 give additional information about possible ACL variables. The extra information
1958 is added on to expand_string_message.
1959
1960 Argument:   the name of the variable
1961 Returns:    nothing
1962 */
1963
1964 static void
1965 check_variable_error_message(uschar *name)
1966 {
1967 if (Ustrncmp(name, "acl_", 4) == 0)
1968   expand_string_message = string_sprintf("%s (%s)", expand_string_message,
1969     (name[4] == 'c' || name[4] == 'm')?
1970       (isalpha(name[5])?
1971         US"6th character of a user-defined ACL variable must be a digit or underscore" :
1972         US"strict_acl_vars is set"    /* Syntax is OK, it has to be this */
1973       ) :
1974       US"user-defined ACL variables must start acl_c or acl_m");
1975 }
1976
1977
1978
1979 /*
1980 Load args from sub array to globals, and call acl_check().
1981 Sub array will be corrupted on return.
1982
1983 Returns:       OK         access is granted by an ACCEPT verb
1984                DISCARD    access is granted by a DISCARD verb
1985                FAIL       access is denied
1986                FAIL_DROP  access is denied; drop the connection
1987                DEFER      can't tell at the moment
1988                ERROR      disaster
1989 */
1990 static int
1991 eval_acl(uschar ** sub, int nsub, uschar ** user_msgp)
1992 {
1993 int i;
1994 uschar *tmp;
1995 int sav_narg = acl_narg;
1996 int ret;
1997 extern int acl_where;
1998
1999 if(--nsub > sizeof(acl_arg)/sizeof(*acl_arg)) nsub = sizeof(acl_arg)/sizeof(*acl_arg);
2000 for (i = 0; i < nsub && sub[i+1]; i++)
2001   {
2002   tmp = acl_arg[i];
2003   acl_arg[i] = sub[i+1];        /* place callers args in the globals */
2004   sub[i+1] = tmp;               /* stash the old args using our caller's storage */
2005   }
2006 acl_narg = i;
2007 while (i < nsub)
2008   {
2009   sub[i+1] = acl_arg[i];
2010   acl_arg[i++] = NULL;
2011   }
2012
2013 DEBUG(D_expand)
2014   debug_printf("expanding: acl: %s  arg: %s%s\n",
2015     sub[0],
2016     acl_narg>0 ? acl_arg[0] : US"<none>",
2017     acl_narg>1 ? " +more"   : "");
2018
2019 ret = acl_eval(acl_where, sub[0], user_msgp, &tmp);
2020
2021 for (i = 0; i < nsub; i++)
2022   acl_arg[i] = sub[i+1];        /* restore old args */
2023 acl_narg = sav_narg;
2024
2025 return ret;
2026 }
2027
2028
2029
2030
2031 /*************************************************
2032 *        Read and evaluate a condition           *
2033 *************************************************/
2034
2035 /*
2036 Arguments:
2037   s        points to the start of the condition text
2038   resetok  points to a BOOL which is written false if it is unsafe to
2039            free memory. Certain condition types (acl) may have side-effect
2040            allocation which must be preserved.
2041   yield    points to a BOOL to hold the result of the condition test;
2042            if NULL, we are just reading through a condition that is
2043            part of an "or" combination to check syntax, or in a state
2044            where the answer isn't required
2045
2046 Returns:   a pointer to the first character after the condition, or
2047            NULL after an error
2048 */
2049
2050 static uschar *
2051 eval_condition(uschar *s, BOOL *resetok, BOOL *yield)
2052 {
2053 BOOL testfor = TRUE;
2054 BOOL tempcond, combined_cond;
2055 BOOL *subcondptr;
2056 BOOL sub2_honour_dollar = TRUE;
2057 int i, rc, cond_type, roffset;
2058 int_eximarith_t num[2];
2059 struct stat statbuf;
2060 uschar name[256];
2061 uschar *sub[10];
2062
2063 const pcre *re;
2064 const uschar *rerror;
2065
2066 for (;;)
2067   {
2068   while (isspace(*s)) s++;
2069   if (*s == '!') { testfor = !testfor; s++; } else break;
2070   }
2071
2072 /* Numeric comparisons are symbolic */
2073
2074 if (*s == '=' || *s == '>' || *s == '<')
2075   {
2076   int p = 0;
2077   name[p++] = *s++;
2078   if (*s == '=')
2079     {
2080     name[p++] = '=';
2081     s++;
2082     }
2083   name[p] = 0;
2084   }
2085
2086 /* All other conditions are named */
2087
2088 else s = read_name(name, 256, s, US"_");
2089
2090 /* If we haven't read a name, it means some non-alpha character is first. */
2091
2092 if (name[0] == 0)
2093   {
2094   expand_string_message = string_sprintf("condition name expected, "
2095     "but found \"%.16s\"", s);
2096   return NULL;
2097   }
2098
2099 /* Find which condition we are dealing with, and switch on it */
2100
2101 cond_type = chop_match(name, cond_table, sizeof(cond_table)/sizeof(uschar *));
2102 switch(cond_type)
2103   {
2104   /* def: tests for a non-empty variable, or for the existence of a header. If
2105   yield == NULL we are in a skipping state, and don't care about the answer. */
2106
2107   case ECOND_DEF:
2108   if (*s != ':')
2109     {
2110     expand_string_message = US"\":\" expected after \"def\"";
2111     return NULL;
2112     }
2113
2114   s = read_name(name, 256, s+1, US"_");
2115
2116   /* Test for a header's existence. If the name contains a closing brace
2117   character, this may be a user error where the terminating colon has been
2118   omitted. Set a flag to adjust a subsequent error message in this case. */
2119
2120   if (Ustrncmp(name, "h_", 2) == 0 ||
2121       Ustrncmp(name, "rh_", 3) == 0 ||
2122       Ustrncmp(name, "bh_", 3) == 0 ||
2123       Ustrncmp(name, "header_", 7) == 0 ||
2124       Ustrncmp(name, "rheader_", 8) == 0 ||
2125       Ustrncmp(name, "bheader_", 8) == 0)
2126     {
2127     s = read_header_name(name, 256, s);
2128     /* {-for-text-editors */
2129     if (Ustrchr(name, '}') != NULL) malformed_header = TRUE;
2130     if (yield != NULL) *yield =
2131       (find_header(name, TRUE, NULL, FALSE, NULL) != NULL) == testfor;
2132     }
2133
2134   /* Test for a variable's having a non-empty value. A non-existent variable
2135   causes an expansion failure. */
2136
2137   else
2138     {
2139     uschar *value = find_variable(name, TRUE, yield == NULL, NULL);
2140     if (value == NULL)
2141       {
2142       expand_string_message = (name[0] == 0)?
2143         string_sprintf("variable name omitted after \"def:\"") :
2144         string_sprintf("unknown variable \"%s\" after \"def:\"", name);
2145       check_variable_error_message(name);
2146       return NULL;
2147       }
2148     if (yield != NULL) *yield = (value[0] != 0) == testfor;
2149     }
2150
2151   return s;
2152
2153
2154   /* first_delivery tests for first delivery attempt */
2155
2156   case ECOND_FIRST_DELIVERY:
2157   if (yield != NULL) *yield = deliver_firsttime == testfor;
2158   return s;
2159
2160
2161   /* queue_running tests for any process started by a queue runner */
2162
2163   case ECOND_QUEUE_RUNNING:
2164   if (yield != NULL) *yield = (queue_run_pid != (pid_t)0) == testfor;
2165   return s;
2166
2167
2168   /* exists:  tests for file existence
2169        isip:  tests for any IP address
2170       isip4:  tests for an IPv4 address
2171       isip6:  tests for an IPv6 address
2172         pam:  does PAM authentication
2173      radius:  does RADIUS authentication
2174    ldapauth:  does LDAP authentication
2175     pwcheck:  does Cyrus SASL pwcheck authentication
2176   */
2177
2178   case ECOND_EXISTS:
2179   case ECOND_ISIP:
2180   case ECOND_ISIP4:
2181   case ECOND_ISIP6:
2182   case ECOND_PAM:
2183   case ECOND_RADIUS:
2184   case ECOND_LDAPAUTH:
2185   case ECOND_PWCHECK:
2186
2187   while (isspace(*s)) s++;
2188   if (*s != '{') goto COND_FAILED_CURLY_START;          /* }-for-text-editors */
2189
2190   sub[0] = expand_string_internal(s+1, TRUE, &s, yield == NULL, TRUE, resetok);
2191   if (sub[0] == NULL) return NULL;
2192   /* {-for-text-editors */
2193   if (*s++ != '}') goto COND_FAILED_CURLY_END;
2194
2195   if (yield == NULL) return s;   /* No need to run the test if skipping */
2196
2197   switch(cond_type)
2198     {
2199     case ECOND_EXISTS:
2200     if ((expand_forbid & RDO_EXISTS) != 0)
2201       {
2202       expand_string_message = US"File existence tests are not permitted";
2203       return NULL;
2204       }
2205     *yield = (Ustat(sub[0], &statbuf) == 0) == testfor;
2206     break;
2207
2208     case ECOND_ISIP:
2209     case ECOND_ISIP4:
2210     case ECOND_ISIP6:
2211     rc = string_is_ip_address(sub[0], NULL);
2212     *yield = ((cond_type == ECOND_ISIP)? (rc != 0) :
2213              (cond_type == ECOND_ISIP4)? (rc == 4) : (rc == 6)) == testfor;
2214     break;
2215
2216     /* Various authentication tests - all optionally compiled */
2217
2218     case ECOND_PAM:
2219     #ifdef SUPPORT_PAM
2220     rc = auth_call_pam(sub[0], &expand_string_message);
2221     goto END_AUTH;
2222     #else
2223     goto COND_FAILED_NOT_COMPILED;
2224     #endif  /* SUPPORT_PAM */
2225
2226     case ECOND_RADIUS:
2227     #ifdef RADIUS_CONFIG_FILE
2228     rc = auth_call_radius(sub[0], &expand_string_message);
2229     goto END_AUTH;
2230     #else
2231     goto COND_FAILED_NOT_COMPILED;
2232     #endif  /* RADIUS_CONFIG_FILE */
2233
2234     case ECOND_LDAPAUTH:
2235     #ifdef LOOKUP_LDAP
2236       {
2237       /* Just to keep the interface the same */
2238       BOOL do_cache;
2239       int old_pool = store_pool;
2240       store_pool = POOL_SEARCH;
2241       rc = eldapauth_find((void *)(-1), NULL, sub[0], Ustrlen(sub[0]), NULL,
2242         &expand_string_message, &do_cache);
2243       store_pool = old_pool;
2244       }
2245     goto END_AUTH;
2246     #else
2247     goto COND_FAILED_NOT_COMPILED;
2248     #endif  /* LOOKUP_LDAP */
2249
2250     case ECOND_PWCHECK:
2251     #ifdef CYRUS_PWCHECK_SOCKET
2252     rc = auth_call_pwcheck(sub[0], &expand_string_message);
2253     goto END_AUTH;
2254     #else
2255     goto COND_FAILED_NOT_COMPILED;
2256     #endif  /* CYRUS_PWCHECK_SOCKET */
2257
2258     #if defined(SUPPORT_PAM) || defined(RADIUS_CONFIG_FILE) || \
2259         defined(LOOKUP_LDAP) || defined(CYRUS_PWCHECK_SOCKET)
2260     END_AUTH:
2261     if (rc == ERROR || rc == DEFER) return NULL;
2262     *yield = (rc == OK) == testfor;
2263     #endif
2264     }
2265   return s;
2266
2267
2268   /* call ACL (in a conditional context).  Accept true, deny false.
2269   Defer is a forced-fail.  Anything set by message= goes to $value.
2270   Up to ten parameters are used; we use the braces round the name+args
2271   like the saslauthd condition does, to permit a variable number of args.
2272   See also the expansion-item version EITEM_ACL and the traditional
2273   acl modifier ACLC_ACL.
2274   Since the ACL may allocate new global variables, tell our caller to not
2275   reclaim memory.
2276   */
2277
2278   case ECOND_ACL:
2279     /* ${if acl {{name}{arg1}{arg2}...}  {yes}{no}} */
2280     {
2281     uschar *user_msg;
2282     BOOL cond = FALSE;
2283     int size = 0;
2284     int ptr = 0;
2285
2286     while (isspace(*s)) s++;
2287     if (*s++ != '{') goto COND_FAILED_CURLY_START;      /*}*/
2288
2289     switch(read_subs(sub, sizeof(sub)/sizeof(*sub), 1,
2290       &s, yield == NULL, TRUE, US"acl", resetok))
2291       {
2292       case 1: expand_string_message = US"too few arguments or bracketing "
2293         "error for acl";
2294       case 2:
2295       case 3: return NULL;
2296       }
2297
2298     *resetok = FALSE;
2299     if (yield != NULL) switch(eval_acl(sub, sizeof(sub)/sizeof(*sub), &user_msg))
2300         {
2301         case OK:
2302           cond = TRUE;
2303         case FAIL:
2304           lookup_value = NULL;
2305           if (user_msg)
2306             {
2307             lookup_value = string_cat(NULL, &size, &ptr, user_msg, Ustrlen(user_msg));
2308             lookup_value[ptr] = '\0';
2309             }
2310           *yield = cond == testfor;
2311           break;
2312
2313         case DEFER:
2314           expand_string_forcedfail = TRUE;
2315         default:
2316           expand_string_message = string_sprintf("error from acl \"%s\"", sub[0]);
2317           return NULL;
2318         }
2319     return s;
2320     }
2321
2322
2323   /* saslauthd: does Cyrus saslauthd authentication. Four parameters are used:
2324
2325      ${if saslauthd {{username}{password}{service}{realm}}  {yes}{no}}
2326
2327   However, the last two are optional. That is why the whole set is enclosed
2328   in their own set of braces. */
2329
2330   case ECOND_SASLAUTHD:
2331   #ifndef CYRUS_SASLAUTHD_SOCKET
2332   goto COND_FAILED_NOT_COMPILED;
2333   #else
2334   while (isspace(*s)) s++;
2335   if (*s++ != '{') goto COND_FAILED_CURLY_START;        /* }-for-text-editors */
2336   switch(read_subs(sub, 4, 2, &s, yield == NULL, TRUE, US"saslauthd", resetok))
2337     {
2338     case 1: expand_string_message = US"too few arguments or bracketing "
2339       "error for saslauthd";
2340     case 2:
2341     case 3: return NULL;
2342     }
2343   if (sub[2] == NULL) sub[3] = NULL;  /* realm if no service */
2344   if (yield != NULL)
2345     {
2346     int rc;
2347     rc = auth_call_saslauthd(sub[0], sub[1], sub[2], sub[3],
2348       &expand_string_message);
2349     if (rc == ERROR || rc == DEFER) return NULL;
2350     *yield = (rc == OK) == testfor;
2351     }
2352   return s;
2353   #endif /* CYRUS_SASLAUTHD_SOCKET */
2354
2355
2356   /* symbolic operators for numeric and string comparison, and a number of
2357   other operators, all requiring two arguments.
2358
2359   crypteq:           encrypts plaintext and compares against an encrypted text,
2360                        using crypt(), crypt16(), MD5 or SHA-1
2361   inlist/inlisti:    checks if first argument is in the list of the second
2362   match:             does a regular expression match and sets up the numerical
2363                        variables if it succeeds
2364   match_address:     matches in an address list
2365   match_domain:      matches in a domain list
2366   match_ip:          matches a host list that is restricted to IP addresses
2367   match_local_part:  matches in a local part list
2368   */
2369
2370   case ECOND_MATCH_ADDRESS:
2371   case ECOND_MATCH_DOMAIN:
2372   case ECOND_MATCH_IP:
2373   case ECOND_MATCH_LOCAL_PART:
2374 #ifndef EXPAND_LISTMATCH_RHS
2375     sub2_honour_dollar = FALSE;
2376 #endif
2377     /* FALLTHROUGH */
2378
2379   case ECOND_CRYPTEQ:
2380   case ECOND_INLIST:
2381   case ECOND_INLISTI:
2382   case ECOND_MATCH:
2383
2384   case ECOND_NUM_L:     /* Numerical comparisons */
2385   case ECOND_NUM_LE:
2386   case ECOND_NUM_E:
2387   case ECOND_NUM_EE:
2388   case ECOND_NUM_G:
2389   case ECOND_NUM_GE:
2390
2391   case ECOND_STR_LT:    /* String comparisons */
2392   case ECOND_STR_LTI:
2393   case ECOND_STR_LE:
2394   case ECOND_STR_LEI:
2395   case ECOND_STR_EQ:
2396   case ECOND_STR_EQI:
2397   case ECOND_STR_GT:
2398   case ECOND_STR_GTI:
2399   case ECOND_STR_GE:
2400   case ECOND_STR_GEI:
2401
2402   for (i = 0; i < 2; i++)
2403     {
2404     /* Sometimes, we don't expand substrings; too many insecure configurations
2405     created using match_address{}{} and friends, where the second param
2406     includes information from untrustworthy sources. */
2407     BOOL honour_dollar = TRUE;
2408     if ((i > 0) && !sub2_honour_dollar)
2409       honour_dollar = FALSE;
2410
2411     while (isspace(*s)) s++;
2412     if (*s != '{')
2413       {
2414       if (i == 0) goto COND_FAILED_CURLY_START;
2415       expand_string_message = string_sprintf("missing 2nd string in {} "
2416         "after \"%s\"", name);
2417       return NULL;
2418       }
2419     sub[i] = expand_string_internal(s+1, TRUE, &s, yield == NULL,
2420         honour_dollar, resetok);
2421     if (sub[i] == NULL) return NULL;
2422     if (*s++ != '}') goto COND_FAILED_CURLY_END;
2423
2424     /* Convert to numerical if required; we know that the names of all the
2425     conditions that compare numbers do not start with a letter. This just saves
2426     checking for them individually. */
2427
2428     if (!isalpha(name[0]) && yield != NULL)
2429       {
2430       if (sub[i][0] == 0)
2431         {
2432         num[i] = 0;
2433         DEBUG(D_expand)
2434           debug_printf("empty string cast to zero for numerical comparison\n");
2435         }
2436       else
2437         {
2438         num[i] = expand_string_integer(sub[i], FALSE);
2439         if (expand_string_message != NULL) return NULL;
2440         }
2441       }
2442     }
2443
2444   /* Result not required */
2445
2446   if (yield == NULL) return s;
2447
2448   /* Do an appropriate comparison */
2449
2450   switch(cond_type)
2451     {
2452     case ECOND_NUM_E:
2453     case ECOND_NUM_EE:
2454     tempcond = (num[0] == num[1]);
2455     break;
2456
2457     case ECOND_NUM_G:
2458     tempcond = (num[0] > num[1]);
2459     break;
2460
2461     case ECOND_NUM_GE:
2462     tempcond = (num[0] >= num[1]);
2463     break;
2464
2465     case ECOND_NUM_L:
2466     tempcond = (num[0] < num[1]);
2467     break;
2468
2469     case ECOND_NUM_LE:
2470     tempcond = (num[0] <= num[1]);
2471     break;
2472
2473     case ECOND_STR_LT:
2474     tempcond = (Ustrcmp(sub[0], sub[1]) < 0);
2475     break;
2476
2477     case ECOND_STR_LTI:
2478     tempcond = (strcmpic(sub[0], sub[1]) < 0);
2479     break;
2480
2481     case ECOND_STR_LE:
2482     tempcond = (Ustrcmp(sub[0], sub[1]) <= 0);
2483     break;
2484
2485     case ECOND_STR_LEI:
2486     tempcond = (strcmpic(sub[0], sub[1]) <= 0);
2487     break;
2488
2489     case ECOND_STR_EQ:
2490     tempcond = (Ustrcmp(sub[0], sub[1]) == 0);
2491     break;
2492
2493     case ECOND_STR_EQI:
2494     tempcond = (strcmpic(sub[0], sub[1]) == 0);
2495     break;
2496
2497     case ECOND_STR_GT:
2498     tempcond = (Ustrcmp(sub[0], sub[1]) > 0);
2499     break;
2500
2501     case ECOND_STR_GTI:
2502     tempcond = (strcmpic(sub[0], sub[1]) > 0);
2503     break;
2504
2505     case ECOND_STR_GE:
2506     tempcond = (Ustrcmp(sub[0], sub[1]) >= 0);
2507     break;
2508
2509     case ECOND_STR_GEI:
2510     tempcond = (strcmpic(sub[0], sub[1]) >= 0);
2511     break;
2512
2513     case ECOND_MATCH:   /* Regular expression match */
2514     re = pcre_compile(CS sub[1], PCRE_COPT, (const char **)&rerror, &roffset,
2515       NULL);
2516     if (re == NULL)
2517       {
2518       expand_string_message = string_sprintf("regular expression error in "
2519         "\"%s\": %s at offset %d", sub[1], rerror, roffset);
2520       return NULL;
2521       }
2522     tempcond = regex_match_and_setup(re, sub[0], 0, -1);
2523     break;
2524
2525     case ECOND_MATCH_ADDRESS:  /* Match in an address list */
2526     rc = match_address_list(sub[0], TRUE, FALSE, &(sub[1]), NULL, -1, 0, NULL);
2527     goto MATCHED_SOMETHING;
2528
2529     case ECOND_MATCH_DOMAIN:   /* Match in a domain list */
2530     rc = match_isinlist(sub[0], &(sub[1]), 0, &domainlist_anchor, NULL,
2531       MCL_DOMAIN + MCL_NOEXPAND, TRUE, NULL);
2532     goto MATCHED_SOMETHING;
2533
2534     case ECOND_MATCH_IP:       /* Match IP address in a host list */
2535     if (sub[0][0] != 0 && string_is_ip_address(sub[0], NULL) == 0)
2536       {
2537       expand_string_message = string_sprintf("\"%s\" is not an IP address",
2538         sub[0]);
2539       return NULL;
2540       }
2541     else
2542       {
2543       unsigned int *nullcache = NULL;
2544       check_host_block cb;
2545
2546       cb.host_name = US"";
2547       cb.host_address = sub[0];
2548
2549       /* If the host address starts off ::ffff: it is an IPv6 address in
2550       IPv4-compatible mode. Find the IPv4 part for checking against IPv4
2551       addresses. */
2552
2553       cb.host_ipv4 = (Ustrncmp(cb.host_address, "::ffff:", 7) == 0)?
2554         cb.host_address + 7 : cb.host_address;
2555
2556       rc = match_check_list(
2557              &sub[1],                   /* the list */
2558              0,                         /* separator character */
2559              &hostlist_anchor,          /* anchor pointer */
2560              &nullcache,                /* cache pointer */
2561              check_host,                /* function for testing */
2562              &cb,                       /* argument for function */
2563              MCL_HOST,                  /* type of check */
2564              sub[0],                    /* text for debugging */
2565              NULL);                     /* where to pass back data */
2566       }
2567     goto MATCHED_SOMETHING;
2568
2569     case ECOND_MATCH_LOCAL_PART:
2570     rc = match_isinlist(sub[0], &(sub[1]), 0, &localpartlist_anchor, NULL,
2571       MCL_LOCALPART + MCL_NOEXPAND, TRUE, NULL);
2572     /* Fall through */
2573     /* VVVVVVVVVVVV */
2574     MATCHED_SOMETHING:
2575     switch(rc)
2576       {
2577       case OK:
2578       tempcond = TRUE;
2579       break;
2580
2581       case FAIL:
2582       tempcond = FALSE;
2583       break;
2584
2585       case DEFER:
2586       expand_string_message = string_sprintf("unable to complete match "
2587         "against \"%s\": %s", sub[1], search_error_message);
2588       return NULL;
2589       }
2590
2591     break;
2592
2593     /* Various "encrypted" comparisons. If the second string starts with
2594     "{" then an encryption type is given. Default to crypt() or crypt16()
2595     (build-time choice). */
2596     /* }-for-text-editors */
2597
2598     case ECOND_CRYPTEQ:
2599     #ifndef SUPPORT_CRYPTEQ
2600     goto COND_FAILED_NOT_COMPILED;
2601     #else
2602     if (strncmpic(sub[1], US"{md5}", 5) == 0)
2603       {
2604       int sublen = Ustrlen(sub[1]+5);
2605       md5 base;
2606       uschar digest[16];
2607
2608       md5_start(&base);
2609       md5_end(&base, (uschar *)sub[0], Ustrlen(sub[0]), digest);
2610
2611       /* If the length that we are comparing against is 24, the MD5 digest
2612       is expressed as a base64 string. This is the way LDAP does it. However,
2613       some other software uses a straightforward hex representation. We assume
2614       this if the length is 32. Other lengths fail. */
2615
2616       if (sublen == 24)
2617         {
2618         uschar *coded = auth_b64encode((uschar *)digest, 16);
2619         DEBUG(D_auth) debug_printf("crypteq: using MD5+B64 hashing\n"
2620           "  subject=%s\n  crypted=%s\n", coded, sub[1]+5);
2621         tempcond = (Ustrcmp(coded, sub[1]+5) == 0);
2622         }
2623       else if (sublen == 32)
2624         {
2625         int i;
2626         uschar coded[36];
2627         for (i = 0; i < 16; i++) sprintf(CS (coded+2*i), "%02X", digest[i]);
2628         coded[32] = 0;
2629         DEBUG(D_auth) debug_printf("crypteq: using MD5+hex hashing\n"
2630           "  subject=%s\n  crypted=%s\n", coded, sub[1]+5);
2631         tempcond = (strcmpic(coded, sub[1]+5) == 0);
2632         }
2633       else
2634         {
2635         DEBUG(D_auth) debug_printf("crypteq: length for MD5 not 24 or 32: "
2636           "fail\n  crypted=%s\n", sub[1]+5);
2637         tempcond = FALSE;
2638         }
2639       }
2640
2641     else if (strncmpic(sub[1], US"{sha1}", 6) == 0)
2642       {
2643       int sublen = Ustrlen(sub[1]+6);
2644       sha1 base;
2645       uschar digest[20];
2646
2647       sha1_start(&base);
2648       sha1_end(&base, (uschar *)sub[0], Ustrlen(sub[0]), digest);
2649
2650       /* If the length that we are comparing against is 28, assume the SHA1
2651       digest is expressed as a base64 string. If the length is 40, assume a
2652       straightforward hex representation. Other lengths fail. */
2653
2654       if (sublen == 28)
2655         {
2656         uschar *coded = auth_b64encode((uschar *)digest, 20);
2657         DEBUG(D_auth) debug_printf("crypteq: using SHA1+B64 hashing\n"
2658           "  subject=%s\n  crypted=%s\n", coded, sub[1]+6);
2659         tempcond = (Ustrcmp(coded, sub[1]+6) == 0);
2660         }
2661       else if (sublen == 40)
2662         {
2663         int i;
2664         uschar coded[44];
2665         for (i = 0; i < 20; i++) sprintf(CS (coded+2*i), "%02X", digest[i]);
2666         coded[40] = 0;
2667         DEBUG(D_auth) debug_printf("crypteq: using SHA1+hex hashing\n"
2668           "  subject=%s\n  crypted=%s\n", coded, sub[1]+6);
2669         tempcond = (strcmpic(coded, sub[1]+6) == 0);
2670         }
2671       else
2672         {
2673         DEBUG(D_auth) debug_printf("crypteq: length for SHA-1 not 28 or 40: "
2674           "fail\n  crypted=%s\n", sub[1]+6);
2675         tempcond = FALSE;
2676         }
2677       }
2678
2679     else   /* {crypt} or {crypt16} and non-{ at start */
2680            /* }-for-text-editors */
2681       {
2682       int which = 0;
2683       uschar *coded;
2684
2685       if (strncmpic(sub[1], US"{crypt}", 7) == 0)
2686         {
2687         sub[1] += 7;
2688         which = 1;
2689         }
2690       else if (strncmpic(sub[1], US"{crypt16}", 9) == 0)
2691         {
2692         sub[1] += 9;
2693         which = 2;
2694         }
2695       else if (sub[1][0] == '{')                /* }-for-text-editors */
2696         {
2697         expand_string_message = string_sprintf("unknown encryption mechanism "
2698           "in \"%s\"", sub[1]);
2699         return NULL;
2700         }
2701
2702       switch(which)
2703         {
2704         case 0:  coded = US DEFAULT_CRYPT(CS sub[0], CS sub[1]); break;
2705         case 1:  coded = US crypt(CS sub[0], CS sub[1]); break;
2706         default: coded = US crypt16(CS sub[0], CS sub[1]); break;
2707         }
2708
2709       #define STR(s) # s
2710       #define XSTR(s) STR(s)
2711       DEBUG(D_auth) debug_printf("crypteq: using %s()\n"
2712         "  subject=%s\n  crypted=%s\n",
2713         (which == 0)? XSTR(DEFAULT_CRYPT) : (which == 1)? "crypt" : "crypt16",
2714         coded, sub[1]);
2715       #undef STR
2716       #undef XSTR
2717
2718       /* If the encrypted string contains fewer than two characters (for the
2719       salt), force failure. Otherwise we get false positives: with an empty
2720       string the yield of crypt() is an empty string! */
2721
2722       tempcond = (Ustrlen(sub[1]) < 2)? FALSE :
2723         (Ustrcmp(coded, sub[1]) == 0);
2724       }
2725     break;
2726     #endif  /* SUPPORT_CRYPTEQ */
2727
2728     case ECOND_INLIST:
2729     case ECOND_INLISTI:
2730       {
2731       int sep = 0;
2732       uschar *save_iterate_item = iterate_item;
2733       int (*compare)(const uschar *, const uschar *);
2734
2735       tempcond = FALSE;
2736       if (cond_type == ECOND_INLISTI)
2737         compare = strcmpic;
2738       else
2739         compare = (int (*)(const uschar *, const uschar *)) strcmp;
2740
2741       while ((iterate_item = string_nextinlist(&sub[1], &sep, NULL, 0)) != NULL)
2742         if (compare(sub[0], iterate_item) == 0)
2743           {
2744           tempcond = TRUE;
2745           break;
2746           }
2747       iterate_item = save_iterate_item;
2748       }
2749
2750     }   /* Switch for comparison conditions */
2751
2752   *yield = tempcond == testfor;
2753   return s;    /* End of comparison conditions */
2754
2755
2756   /* and/or: computes logical and/or of several conditions */
2757
2758   case ECOND_AND:
2759   case ECOND_OR:
2760   subcondptr = (yield == NULL)? NULL : &tempcond;
2761   combined_cond = (cond_type == ECOND_AND);
2762
2763   while (isspace(*s)) s++;
2764   if (*s++ != '{') goto COND_FAILED_CURLY_START;        /* }-for-text-editors */
2765
2766   for (;;)
2767     {
2768     while (isspace(*s)) s++;
2769     /* {-for-text-editors */
2770     if (*s == '}') break;
2771     if (*s != '{')                                      /* }-for-text-editors */
2772       {
2773       expand_string_message = string_sprintf("each subcondition "
2774         "inside an \"%s{...}\" condition must be in its own {}", name);
2775       return NULL;
2776       }
2777
2778     if (!(s = eval_condition(s+1, resetok, subcondptr)))
2779       {
2780       expand_string_message = string_sprintf("%s inside \"%s{...}\" condition",
2781         expand_string_message, name);
2782       return NULL;
2783       }
2784     while (isspace(*s)) s++;
2785
2786     /* {-for-text-editors */
2787     if (*s++ != '}')
2788       {
2789       /* {-for-text-editors */
2790       expand_string_message = string_sprintf("missing } at end of condition "
2791         "inside \"%s\" group", name);
2792       return NULL;
2793       }
2794
2795     if (yield != NULL)
2796       {
2797       if (cond_type == ECOND_AND)
2798         {
2799         combined_cond &= tempcond;
2800         if (!combined_cond) subcondptr = NULL;  /* once false, don't */
2801         }                                       /* evaluate any more */
2802       else
2803         {
2804         combined_cond |= tempcond;
2805         if (combined_cond) subcondptr = NULL;   /* once true, don't */
2806         }                                       /* evaluate any more */
2807       }
2808     }
2809
2810   if (yield != NULL) *yield = (combined_cond == testfor);
2811   return ++s;
2812
2813
2814   /* forall/forany: iterates a condition with different values */
2815
2816   case ECOND_FORALL:
2817   case ECOND_FORANY:
2818     {
2819     int sep = 0;
2820     uschar *save_iterate_item = iterate_item;
2821
2822     while (isspace(*s)) s++;
2823     if (*s++ != '{') goto COND_FAILED_CURLY_START;      /* }-for-text-editors */
2824     sub[0] = expand_string_internal(s, TRUE, &s, (yield == NULL), TRUE, resetok);
2825     if (sub[0] == NULL) return NULL;
2826     /* {-for-text-editors */
2827     if (*s++ != '}') goto COND_FAILED_CURLY_END;
2828
2829     while (isspace(*s)) s++;
2830     if (*s++ != '{') goto COND_FAILED_CURLY_START;      /* }-for-text-editors */
2831
2832     sub[1] = s;
2833
2834     /* Call eval_condition once, with result discarded (as if scanning a
2835     "false" part). This allows us to find the end of the condition, because if
2836     the list it empty, we won't actually evaluate the condition for real. */
2837
2838     if (!(s = eval_condition(sub[1], resetok, NULL)))
2839       {
2840       expand_string_message = string_sprintf("%s inside \"%s\" condition",
2841         expand_string_message, name);
2842       return NULL;
2843       }
2844     while (isspace(*s)) s++;
2845
2846     /* {-for-text-editors */
2847     if (*s++ != '}')
2848       {
2849       /* {-for-text-editors */
2850       expand_string_message = string_sprintf("missing } at end of condition "
2851         "inside \"%s\"", name);
2852       return NULL;
2853       }
2854
2855     if (yield != NULL) *yield = !testfor;
2856     while ((iterate_item = string_nextinlist(&sub[0], &sep, NULL, 0)) != NULL)
2857       {
2858       DEBUG(D_expand) debug_printf("%s: $item = \"%s\"\n", name, iterate_item);
2859       if (!eval_condition(sub[1], resetok, &tempcond))
2860         {
2861         expand_string_message = string_sprintf("%s inside \"%s\" condition",
2862           expand_string_message, name);
2863         iterate_item = save_iterate_item;
2864         return NULL;
2865         }
2866       DEBUG(D_expand) debug_printf("%s: condition evaluated to %s\n", name,
2867         tempcond? "true":"false");
2868
2869       if (yield != NULL) *yield = (tempcond == testfor);
2870       if (tempcond == (cond_type == ECOND_FORANY)) break;
2871       }
2872
2873     iterate_item = save_iterate_item;
2874     return s;
2875     }
2876
2877
2878   /* The bool{} expansion condition maps a string to boolean.
2879   The values supported should match those supported by the ACL condition
2880   (acl.c, ACLC_CONDITION) so that we keep to a minimum the different ideas
2881   of true/false.  Note that Router "condition" rules have a different
2882   interpretation, where general data can be used and only a few values
2883   map to FALSE.
2884   Note that readconf.c boolean matching, for boolean configuration options,
2885   only matches true/yes/false/no.
2886   The bool_lax{} condition matches the Router logic, which is much more
2887   liberal. */
2888   case ECOND_BOOL:
2889   case ECOND_BOOL_LAX:
2890     {
2891     uschar *sub_arg[1];
2892     uschar *t, *t2;
2893     uschar *ourname;
2894     size_t len;
2895     BOOL boolvalue = FALSE;
2896     while (isspace(*s)) s++;
2897     if (*s != '{') goto COND_FAILED_CURLY_START;        /* }-for-text-editors */
2898     ourname = cond_type == ECOND_BOOL_LAX ? US"bool_lax" : US"bool";
2899     switch(read_subs(sub_arg, 1, 1, &s, yield == NULL, FALSE, ourname, resetok))
2900       {
2901       case 1: expand_string_message = string_sprintf(
2902                   "too few arguments or bracketing error for %s",
2903                   ourname);
2904       /*FALLTHROUGH*/
2905       case 2:
2906       case 3: return NULL;
2907       }
2908     t = sub_arg[0];
2909     while (isspace(*t)) t++;
2910     len = Ustrlen(t);
2911     if (len)
2912       {
2913       /* trailing whitespace: seems like a good idea to ignore it too */
2914       t2 = t + len - 1;
2915       while (isspace(*t2)) t2--;
2916       if (t2 != (t + len))
2917         {
2918         *++t2 = '\0';
2919         len = t2 - t;
2920         }
2921       }
2922     DEBUG(D_expand)
2923       debug_printf("considering %s: %s\n", ourname, len ? t : US"<empty>");
2924     /* logic for the lax case from expand_check_condition(), which also does
2925     expands, and the logic is both short and stable enough that there should
2926     be no maintenance burden from replicating it. */
2927     if (len == 0)
2928       boolvalue = FALSE;
2929     else if (*t == '-'
2930              ? Ustrspn(t+1, "0123456789") == len-1
2931              : Ustrspn(t,   "0123456789") == len)
2932       {
2933       boolvalue = (Uatoi(t) == 0) ? FALSE : TRUE;
2934       /* expand_check_condition only does a literal string "0" check */
2935       if ((cond_type == ECOND_BOOL_LAX) && (len > 1))
2936         boolvalue = TRUE;
2937       }
2938     else if (strcmpic(t, US"true") == 0 || strcmpic(t, US"yes") == 0)
2939       boolvalue = TRUE;
2940     else if (strcmpic(t, US"false") == 0 || strcmpic(t, US"no") == 0)
2941       boolvalue = FALSE;
2942     else if (cond_type == ECOND_BOOL_LAX)
2943       boolvalue = TRUE;
2944     else
2945       {
2946       expand_string_message = string_sprintf("unrecognised boolean "
2947        "value \"%s\"", t);
2948       return NULL;
2949       }
2950     if (yield != NULL) *yield = (boolvalue == testfor);
2951     return s;
2952     }
2953
2954   /* Unknown condition */
2955
2956   default:
2957   expand_string_message = string_sprintf("unknown condition \"%s\"", name);
2958   return NULL;
2959   }   /* End switch on condition type */
2960
2961 /* Missing braces at start and end of data */
2962
2963 COND_FAILED_CURLY_START:
2964 expand_string_message = string_sprintf("missing { after \"%s\"", name);
2965 return NULL;
2966
2967 COND_FAILED_CURLY_END:
2968 expand_string_message = string_sprintf("missing } at end of \"%s\" condition",
2969   name);
2970 return NULL;
2971
2972 /* A condition requires code that is not compiled */
2973
2974 #if !defined(SUPPORT_PAM) || !defined(RADIUS_CONFIG_FILE) || \
2975     !defined(LOOKUP_LDAP) || !defined(CYRUS_PWCHECK_SOCKET) || \
2976     !defined(SUPPORT_CRYPTEQ) || !defined(CYRUS_SASLAUTHD_SOCKET)
2977 COND_FAILED_NOT_COMPILED:
2978 expand_string_message = string_sprintf("support for \"%s\" not compiled",
2979   name);
2980 return NULL;
2981 #endif
2982 }
2983
2984
2985
2986
2987 /*************************************************
2988 *          Save numerical variables              *
2989 *************************************************/
2990
2991 /* This function is called from items such as "if" that want to preserve and
2992 restore the numbered variables.
2993
2994 Arguments:
2995   save_expand_string    points to an array of pointers to set
2996   save_expand_nlength   points to an array of ints for the lengths
2997
2998 Returns:                the value of expand max to save
2999 */
3000
3001 static int
3002 save_expand_strings(uschar **save_expand_nstring, int *save_expand_nlength)
3003 {
3004 int i;
3005 for (i = 0; i <= expand_nmax; i++)
3006   {
3007   save_expand_nstring[i] = expand_nstring[i];
3008   save_expand_nlength[i] = expand_nlength[i];
3009   }
3010 return expand_nmax;
3011 }
3012
3013
3014
3015 /*************************************************
3016 *           Restore numerical variables          *
3017 *************************************************/
3018
3019 /* This function restored saved values of numerical strings.
3020
3021 Arguments:
3022   save_expand_nmax      the number of strings to restore
3023   save_expand_string    points to an array of pointers
3024   save_expand_nlength   points to an array of ints
3025
3026 Returns:                nothing
3027 */
3028
3029 static void
3030 restore_expand_strings(int save_expand_nmax, uschar **save_expand_nstring,
3031   int *save_expand_nlength)
3032 {
3033 int i;
3034 expand_nmax = save_expand_nmax;
3035 for (i = 0; i <= expand_nmax; i++)
3036   {
3037   expand_nstring[i] = save_expand_nstring[i];
3038   expand_nlength[i] = save_expand_nlength[i];
3039   }
3040 }
3041
3042
3043
3044
3045
3046 /*************************************************
3047 *            Handle yes/no substrings            *
3048 *************************************************/
3049
3050 /* This function is used by ${if}, ${lookup} and ${extract} to handle the
3051 alternative substrings that depend on whether or not the condition was true,
3052 or the lookup or extraction succeeded. The substrings always have to be
3053 expanded, to check their syntax, but "skipping" is set when the result is not
3054 needed - this avoids unnecessary nested lookups.
3055
3056 Arguments:
3057   skipping       TRUE if we were skipping when this item was reached
3058   yes            TRUE if the first string is to be used, else use the second
3059   save_lookup    a value to put back into lookup_value before the 2nd expansion
3060   sptr           points to the input string pointer
3061   yieldptr       points to the output string pointer
3062   sizeptr        points to the output string size
3063   ptrptr         points to the output string pointer
3064   type           "lookup" or "if" or "extract" or "run", for error message
3065   resetok        if not NULL, pointer to flag - write FALSE if unsafe to reset
3066                 the store.
3067
3068 Returns:         0 OK; lookup_value has been reset to save_lookup
3069                  1 expansion failed
3070                  2 expansion failed because of bracketing error
3071 */
3072
3073 static int
3074 process_yesno(BOOL skipping, BOOL yes, uschar *save_lookup, uschar **sptr,
3075   uschar **yieldptr, int *sizeptr, int *ptrptr, uschar *type, BOOL *resetok)
3076 {
3077 int rc = 0;
3078 uschar *s = *sptr;    /* Local value */
3079 uschar *sub1, *sub2;
3080
3081 /* If there are no following strings, we substitute the contents of $value for
3082 lookups and for extractions in the success case. For the ${if item, the string
3083 "true" is substituted. In the fail case, nothing is substituted for all three
3084 items. */
3085
3086 while (isspace(*s)) s++;
3087 if (*s == '}')
3088   {
3089   if (type[0] == 'i')
3090     {
3091     if (yes) *yieldptr = string_cat(*yieldptr, sizeptr, ptrptr, US"true", 4);
3092     }
3093   else
3094     {
3095     if (yes && lookup_value != NULL)
3096       *yieldptr = string_cat(*yieldptr, sizeptr, ptrptr, lookup_value,
3097         Ustrlen(lookup_value));
3098     lookup_value = save_lookup;
3099     }
3100   s++;
3101   goto RETURN;
3102   }
3103
3104 /* The first following string must be braced. */
3105
3106 if (*s++ != '{') goto FAILED_CURLY;
3107
3108 /* Expand the first substring. Forced failures are noticed only if we actually
3109 want this string. Set skipping in the call in the fail case (this will always
3110 be the case if we were already skipping). */
3111
3112 sub1 = expand_string_internal(s, TRUE, &s, !yes, TRUE, resetok);
3113 if (sub1 == NULL && (yes || !expand_string_forcedfail)) goto FAILED;
3114 expand_string_forcedfail = FALSE;
3115 if (*s++ != '}') goto FAILED_CURLY;
3116
3117 /* If we want the first string, add it to the output */
3118
3119 if (yes)
3120   *yieldptr = string_cat(*yieldptr, sizeptr, ptrptr, sub1, Ustrlen(sub1));
3121
3122 /* If this is called from a lookup or an extract, we want to restore $value to
3123 what it was at the start of the item, so that it has this value during the
3124 second string expansion. For the call from "if" or "run" to this function,
3125 save_lookup is set to lookup_value, so that this statement does nothing. */
3126
3127 lookup_value = save_lookup;
3128
3129 /* There now follows either another substring, or "fail", or nothing. This
3130 time, forced failures are noticed only if we want the second string. We must
3131 set skipping in the nested call if we don't want this string, or if we were
3132 already skipping. */
3133
3134 while (isspace(*s)) s++;
3135 if (*s == '{')
3136   {
3137   sub2 = expand_string_internal(s+1, TRUE, &s, yes || skipping, TRUE, resetok);
3138   if (sub2 == NULL && (!yes || !expand_string_forcedfail)) goto FAILED;
3139   expand_string_forcedfail = FALSE;
3140   if (*s++ != '}') goto FAILED_CURLY;
3141
3142   /* If we want the second string, add it to the output */
3143
3144   if (!yes)
3145     *yieldptr = string_cat(*yieldptr, sizeptr, ptrptr, sub2, Ustrlen(sub2));
3146   }
3147
3148 /* If there is no second string, but the word "fail" is present when the use of
3149 the second string is wanted, set a flag indicating it was a forced failure
3150 rather than a syntactic error. Swallow the terminating } in case this is nested
3151 inside another lookup or if or extract. */
3152
3153 else if (*s != '}')
3154   {
3155   uschar name[256];
3156   s = read_name(name, sizeof(name), s, US"_");
3157   if (Ustrcmp(name, "fail") == 0)
3158     {
3159     if (!yes && !skipping)
3160       {
3161       while (isspace(*s)) s++;
3162       if (*s++ != '}') goto FAILED_CURLY;
3163       expand_string_message =
3164         string_sprintf("\"%s\" failed and \"fail\" requested", type);
3165       expand_string_forcedfail = TRUE;
3166       goto FAILED;
3167       }
3168     }
3169   else
3170     {
3171     expand_string_message =
3172       string_sprintf("syntax error in \"%s\" item - \"fail\" expected", type);
3173     goto FAILED;
3174     }
3175   }
3176
3177 /* All we have to do now is to check on the final closing brace. */
3178
3179 while (isspace(*s)) s++;
3180 if (*s++ == '}') goto RETURN;
3181
3182 /* Get here if there is a bracketing failure */
3183
3184 FAILED_CURLY:
3185 rc++;
3186
3187 /* Get here for other failures */
3188
3189 FAILED:
3190 rc++;
3191
3192 /* Update the input pointer value before returning */
3193
3194 RETURN:
3195 *sptr = s;
3196 return rc;
3197 }
3198
3199
3200
3201
3202 /*************************************************
3203 *    Handle MD5 or SHA-1 computation for HMAC    *
3204 *************************************************/
3205
3206 /* These are some wrapping functions that enable the HMAC code to be a bit
3207 cleaner. A good compiler will spot the tail recursion.
3208
3209 Arguments:
3210   type         HMAC_MD5 or HMAC_SHA1
3211   remaining    are as for the cryptographic hash functions
3212
3213 Returns:       nothing
3214 */
3215
3216 static void
3217 chash_start(int type, void *base)
3218 {
3219 if (type == HMAC_MD5)
3220   md5_start((md5 *)base);
3221 else
3222   sha1_start((sha1 *)base);
3223 }
3224
3225 static void
3226 chash_mid(int type, void *base, uschar *string)
3227 {
3228 if (type == HMAC_MD5)
3229   md5_mid((md5 *)base, string);
3230 else
3231   sha1_mid((sha1 *)base, string);
3232 }
3233
3234 static void
3235 chash_end(int type, void *base, uschar *string, int length, uschar *digest)
3236 {
3237 if (type == HMAC_MD5)
3238   md5_end((md5 *)base, string, length, digest);
3239 else
3240   sha1_end((sha1 *)base, string, length, digest);
3241 }
3242
3243
3244
3245
3246
3247 /********************************************************
3248 * prvs: Get last three digits of days since Jan 1, 1970 *
3249 ********************************************************/
3250
3251 /* This is needed to implement the "prvs" BATV reverse
3252    path signing scheme
3253
3254 Argument: integer "days" offset to add or substract to
3255           or from the current number of days.
3256
3257 Returns:  pointer to string containing the last three
3258           digits of the number of days since Jan 1, 1970,
3259           modified by the offset argument, NULL if there
3260           was an error in the conversion.
3261
3262 */
3263
3264 static uschar *
3265 prvs_daystamp(int day_offset)
3266 {
3267 uschar *days = store_get(32);                /* Need at least 24 for cases */
3268 (void)string_format(days, 32, TIME_T_FMT,    /* where TIME_T_FMT is %lld */
3269   (time(NULL) + day_offset*86400)/86400);
3270 return (Ustrlen(days) >= 3) ? &days[Ustrlen(days)-3] : US"100";
3271 }
3272
3273
3274
3275 /********************************************************
3276 *   prvs: perform HMAC-SHA1 computation of prvs bits    *
3277 ********************************************************/
3278
3279 /* This is needed to implement the "prvs" BATV reverse
3280    path signing scheme
3281
3282 Arguments:
3283   address RFC2821 Address to use
3284       key The key to use (must be less than 64 characters
3285           in size)
3286   key_num Single-digit key number to use. Defaults to
3287           '0' when NULL.
3288
3289 Returns:  pointer to string containing the first three
3290           bytes of the final hash in hex format, NULL if
3291           there was an error in the process.
3292 */
3293
3294 static uschar *
3295 prvs_hmac_sha1(uschar *address, uschar *key, uschar *key_num, uschar *daystamp)
3296 {
3297 uschar *hash_source, *p;
3298 int size = 0,offset = 0,i;
3299 sha1 sha1_base;
3300 void *use_base = &sha1_base;
3301 uschar innerhash[20];
3302 uschar finalhash[20];
3303 uschar innerkey[64];
3304 uschar outerkey[64];
3305 uschar *finalhash_hex = store_get(40);
3306
3307 if (key_num == NULL)
3308   key_num = US"0";
3309
3310 if (Ustrlen(key) > 64)
3311   return NULL;
3312
3313 hash_source = string_cat(NULL,&size,&offset,key_num,1);
3314 string_cat(hash_source,&size,&offset,daystamp,3);
3315 string_cat(hash_source,&size,&offset,address,Ustrlen(address));
3316 hash_source[offset] = '\0';
3317
3318 DEBUG(D_expand) debug_printf("prvs: hash source is '%s'\n", hash_source);
3319
3320 memset(innerkey, 0x36, 64);
3321 memset(outerkey, 0x5c, 64);
3322
3323 for (i = 0; i < Ustrlen(key); i++)
3324   {
3325   innerkey[i] ^= key[i];
3326   outerkey[i] ^= key[i];
3327   }
3328
3329 chash_start(HMAC_SHA1, use_base);
3330 chash_mid(HMAC_SHA1, use_base, innerkey);
3331 chash_end(HMAC_SHA1, use_base, hash_source, offset, innerhash);
3332
3333 chash_start(HMAC_SHA1, use_base);
3334 chash_mid(HMAC_SHA1, use_base, outerkey);
3335 chash_end(HMAC_SHA1, use_base, innerhash, 20, finalhash);
3336
3337 p = finalhash_hex;
3338 for (i = 0; i < 3; i++)
3339   {
3340   *p++ = hex_digits[(finalhash[i] & 0xf0) >> 4];
3341   *p++ = hex_digits[finalhash[i] & 0x0f];
3342   }
3343 *p = '\0';
3344
3345 return finalhash_hex;
3346 }
3347
3348
3349
3350
3351 /*************************************************
3352 *        Join a file onto the output string      *
3353 *************************************************/
3354
3355 /* This is used for readfile and after a run expansion. It joins the contents
3356 of a file onto the output string, globally replacing newlines with a given
3357 string (optionally). The file is closed at the end.
3358
3359 Arguments:
3360   f            the FILE
3361   yield        pointer to the expandable string
3362   sizep        pointer to the current size
3363   ptrp         pointer to the current position
3364   eol          newline replacement string, or NULL
3365
3366 Returns:       new value of string pointer
3367 */
3368
3369 static uschar *
3370 cat_file(FILE *f, uschar *yield, int *sizep, int *ptrp, uschar *eol)
3371 {
3372 int eollen;
3373 uschar buffer[1024];
3374
3375 eollen = (eol == NULL)? 0 : Ustrlen(eol);
3376
3377 while (Ufgets(buffer, sizeof(buffer), f) != NULL)
3378   {
3379   int len = Ustrlen(buffer);
3380   if (eol != NULL && buffer[len-1] == '\n') len--;
3381   yield = string_cat(yield, sizep, ptrp, buffer, len);
3382   if (buffer[len] != 0)
3383     yield = string_cat(yield, sizep, ptrp, eol, eollen);
3384   }
3385
3386 if (yield != NULL) yield[*ptrp] = 0;
3387
3388 return yield;
3389 }
3390
3391
3392
3393
3394 /*************************************************
3395 *          Evaluate numeric expression           *
3396 *************************************************/
3397
3398 /* This is a set of mutually recursive functions that evaluate an arithmetic
3399 expression involving + - * / % & | ^ ~ << >> and parentheses. The only one of
3400 these functions that is called from elsewhere is eval_expr, whose interface is:
3401
3402 Arguments:
3403   sptr        pointer to the pointer to the string - gets updated
3404   decimal     TRUE if numbers are to be assumed decimal
3405   error       pointer to where to put an error message - must be NULL on input
3406   endket      TRUE if ')' must terminate - FALSE for external call
3407
3408 Returns:      on success: the value of the expression, with *error still NULL
3409               on failure: an undefined value, with *error = a message
3410 */
3411
3412 static int_eximarith_t eval_op_or(uschar **, BOOL, uschar **);
3413
3414
3415 static int_eximarith_t
3416 eval_expr(uschar **sptr, BOOL decimal, uschar **error, BOOL endket)
3417 {
3418 uschar *s = *sptr;
3419 int_eximarith_t x = eval_op_or(&s, decimal, error);
3420 if (*error == NULL)
3421   {
3422   if (endket)
3423     {
3424     if (*s != ')')
3425       *error = US"expecting closing parenthesis";
3426     else
3427       while (isspace(*(++s)));
3428     }
3429   else if (*s != 0) *error = US"expecting operator";
3430   }
3431 *sptr = s;
3432 return x;
3433 }
3434
3435
3436 static int_eximarith_t
3437 eval_number(uschar **sptr, BOOL decimal, uschar **error)
3438 {
3439 register int c;
3440 int_eximarith_t n;
3441 uschar *s = *sptr;
3442 while (isspace(*s)) s++;
3443 c = *s;
3444 if (isdigit(c))
3445   {
3446   int count;
3447   (void)sscanf(CS s, (decimal? SC_EXIM_DEC "%n" : SC_EXIM_ARITH "%n"), &n, &count);
3448   s += count;
3449   switch (tolower(*s))
3450     {
3451     default: break;
3452     case 'k': n *= 1024; s++; break;
3453     case 'm': n *= 1024*1024; s++; break;
3454     case 'g': n *= 1024*1024*1024; s++; break;
3455     }
3456   while (isspace (*s)) s++;
3457   }
3458 else if (c == '(')
3459   {
3460   s++;
3461   n = eval_expr(&s, decimal, error, 1);
3462   }
3463 else
3464   {
3465   *error = US"expecting number or opening parenthesis";
3466   n = 0;
3467   }
3468 *sptr = s;
3469 return n;
3470 }
3471
3472
3473 static int_eximarith_t
3474 eval_op_unary(uschar **sptr, BOOL decimal, uschar **error)
3475 {
3476 uschar *s = *sptr;
3477 int_eximarith_t x;
3478 while (isspace(*s)) s++;
3479 if (*s == '+' || *s == '-' || *s == '~')
3480   {
3481   int op = *s++;
3482   x = eval_op_unary(&s, decimal, error);
3483   if (op == '-') x = -x;
3484     else if (op == '~') x = ~x;
3485   }
3486 else
3487   {
3488   x = eval_number(&s, decimal, error);
3489   }
3490 *sptr = s;
3491 return x;
3492 }
3493
3494
3495 static int_eximarith_t
3496 eval_op_mult(uschar **sptr, BOOL decimal, uschar **error)
3497 {
3498 uschar *s = *sptr;
3499 int_eximarith_t x = eval_op_unary(&s, decimal, error);
3500 if (*error == NULL)
3501   {
3502   while (*s == '*' || *s == '/' || *s == '%')
3503     {
3504     int op = *s++;
3505     int_eximarith_t y = eval_op_unary(&s, decimal, error);
3506     if (*error != NULL) break;
3507     /* SIGFPE both on div/mod by zero and on INT_MIN / -1, which would give
3508      * a value of INT_MAX+1. Note that INT_MIN * -1 gives INT_MIN for me, which
3509      * is a bug somewhere in [gcc 4.2.1, FreeBSD, amd64].  In fact, -N*-M where
3510      * -N*M is INT_MIN will yielf INT_MIN.
3511      * Since we don't support floating point, this is somewhat simpler.
3512      * Ideally, we'd return an error, but since we overflow for all other
3513      * arithmetic, consistency suggests otherwise, but what's the correct value
3514      * to use?  There is none.
3515      * The C standard guarantees overflow for unsigned arithmetic but signed
3516      * overflow invokes undefined behaviour; in practice, this is overflow
3517      * except for converting INT_MIN to INT_MAX+1.  We also can't guarantee
3518      * that long/longlong larger than int are available, or we could just work
3519      * with larger types.  We should consider whether to guarantee 32bit eval
3520      * and 64-bit working variables, with errors returned.  For now ...
3521      * So, the only SIGFPEs occur with a non-shrinking div/mod, thus -1; we
3522      * can just let the other invalid results occur otherwise, as they have
3523      * until now.  For this one case, we can coerce.
3524      */
3525     if (y == -1 && x == EXIM_ARITH_MIN && op != '*')
3526       {
3527       DEBUG(D_expand)
3528         debug_printf("Integer exception dodging: " PR_EXIM_ARITH "%c-1 coerced to " PR_EXIM_ARITH "\n",
3529             EXIM_ARITH_MIN, op, EXIM_ARITH_MAX);
3530       x = EXIM_ARITH_MAX;
3531       continue;
3532       }
3533     if (op == '*')
3534       x *= y;
3535     else
3536       {
3537       if (y == 0)
3538         {
3539         *error = (op == '/') ? US"divide by zero" : US"modulo by zero";
3540         x = 0;
3541         break;
3542         }
3543       if (op == '/')
3544         x /= y;
3545       else
3546         x %= y;
3547       }
3548     }
3549   }
3550 *sptr = s;
3551 return x;
3552 }
3553
3554
3555 static int_eximarith_t
3556 eval_op_sum(uschar **sptr, BOOL decimal, uschar **error)
3557 {
3558 uschar *s = *sptr;
3559 int_eximarith_t x = eval_op_mult(&s, decimal, error);
3560 if (*error == NULL)
3561   {
3562   while (*s == '+' || *s == '-')
3563     {
3564     int op = *s++;
3565     int_eximarith_t y = eval_op_mult(&s, decimal, error);
3566     if (*error != NULL) break;
3567     if (op == '+') x += y; else x -= y;
3568     }
3569   }
3570 *sptr = s;
3571 return x;
3572 }
3573
3574
3575 static int_eximarith_t
3576 eval_op_shift(uschar **sptr, BOOL decimal, uschar **error)
3577 {
3578 uschar *s = *sptr;
3579 int_eximarith_t x = eval_op_sum(&s, decimal, error);
3580 if (*error == NULL)
3581   {
3582   while ((*s == '<' || *s == '>') && s[1] == s[0])
3583     {
3584     int_eximarith_t y;
3585     int op = *s++;
3586     s++;
3587     y = eval_op_sum(&s, decimal, error);
3588     if (*error != NULL) break;
3589     if (op == '<') x <<= y; else x >>= y;
3590     }
3591   }
3592 *sptr = s;
3593 return x;
3594 }
3595
3596
3597 static int_eximarith_t
3598 eval_op_and(uschar **sptr, BOOL decimal, uschar **error)
3599 {
3600 uschar *s = *sptr;
3601 int_eximarith_t x = eval_op_shift(&s, decimal, error);
3602 if (*error == NULL)
3603   {
3604   while (*s == '&')
3605     {
3606     int_eximarith_t y;
3607     s++;
3608     y = eval_op_shift(&s, decimal, error);
3609     if (*error != NULL) break;
3610     x &= y;
3611     }
3612   }
3613 *sptr = s;
3614 return x;
3615 }
3616
3617
3618 static int_eximarith_t
3619 eval_op_xor(uschar **sptr, BOOL decimal, uschar **error)
3620 {
3621 uschar *s = *sptr;
3622 int_eximarith_t x = eval_op_and(&s, decimal, error);
3623 if (*error == NULL)
3624   {
3625   while (*s == '^')
3626     {
3627     int_eximarith_t y;
3628     s++;
3629     y = eval_op_and(&s, decimal, error);
3630     if (*error != NULL) break;
3631     x ^= y;
3632     }
3633   }
3634 *sptr = s;
3635 return x;
3636 }
3637
3638
3639 static int_eximarith_t
3640 eval_op_or(uschar **sptr, BOOL decimal, uschar **error)
3641 {
3642 uschar *s = *sptr;
3643 int_eximarith_t x = eval_op_xor(&s, decimal, error);
3644 if (*error == NULL)
3645   {
3646   while (*s == '|')
3647     {
3648     int_eximarith_t y;
3649     s++;
3650     y = eval_op_xor(&s, decimal, error);
3651     if (*error != NULL) break;
3652     x |= y;
3653     }
3654   }
3655 *sptr = s;
3656 return x;
3657 }
3658
3659
3660
3661 /*************************************************
3662 *                 Expand string                  *
3663 *************************************************/
3664
3665 /* Returns either an unchanged string, or the expanded string in stacking pool
3666 store. Interpreted sequences are:
3667
3668    \...                    normal escaping rules
3669    $name                   substitutes the variable
3670    ${name}                 ditto
3671    ${op:string}            operates on the expanded string value
3672    ${item{arg1}{arg2}...}  expands the args and then does the business
3673                              some literal args are not enclosed in {}
3674
3675 There are now far too many operators and item types to make it worth listing
3676 them here in detail any more.
3677
3678 We use an internal routine recursively to handle embedded substrings. The
3679 external function follows. The yield is NULL if the expansion failed, and there
3680 are two cases: if something collapsed syntactically, or if "fail" was given
3681 as the action on a lookup failure. These can be distinguised by looking at the
3682 variable expand_string_forcedfail, which is TRUE in the latter case.
3683
3684 The skipping flag is set true when expanding a substring that isn't actually
3685 going to be used (after "if" or "lookup") and it prevents lookups from
3686 happening lower down.
3687
3688 Store usage: At start, a store block of the length of the input plus 64
3689 is obtained. This is expanded as necessary by string_cat(), which might have to
3690 get a new block, or might be able to expand the original. At the end of the
3691 function we can release any store above that portion of the yield block that
3692 was actually used. In many cases this will be optimal.
3693
3694 However: if the first item in the expansion is a variable name or header name,
3695 we reset the store before processing it; if the result is in fresh store, we
3696 use that without copying. This is helpful for expanding strings like
3697 $message_headers which can get very long.
3698
3699 There's a problem if a ${dlfunc item has side-effects that cause allocation,
3700 since resetting the store at the end of the expansion will free store that was
3701 allocated by the plugin code as well as the slop after the expanded string. So
3702 we skip any resets if ${dlfunc } has been used. The same applies for ${acl }
3703 and, given the acl condition, ${if }. This is an unfortunate consequence of
3704 string expansion becoming too powerful.
3705
3706 Arguments:
3707   string         the string to be expanded
3708   ket_ends       true if expansion is to stop at }
3709   left           if not NULL, a pointer to the first character after the
3710                  expansion is placed here (typically used with ket_ends)
3711   skipping       TRUE for recursive calls when the value isn't actually going
3712                  to be used (to allow for optimisation)
3713   honour_dollar  TRUE if $ is to be expanded,
3714                  FALSE if it's just another character
3715   resetok_p      if not NULL, pointer to flag - write FALSE if unsafe to reset
3716                  the store.
3717
3718 Returns:         NULL if expansion fails:
3719                    expand_string_forcedfail is set TRUE if failure was forced
3720                    expand_string_message contains a textual error message
3721                  a pointer to the expanded string on success
3722 */
3723
3724 static uschar *
3725 expand_string_internal(uschar *string, BOOL ket_ends, uschar **left,
3726   BOOL skipping, BOOL honour_dollar, BOOL *resetok_p)
3727 {
3728 int ptr = 0;
3729 int size = Ustrlen(string)+ 64;
3730 int item_type;
3731 uschar *yield = store_get(size);
3732 uschar *s = string;
3733 uschar *save_expand_nstring[EXPAND_MAXN+1];
3734 int save_expand_nlength[EXPAND_MAXN+1];
3735 BOOL resetok = TRUE;
3736
3737 expand_string_forcedfail = FALSE;
3738 expand_string_message = US"";
3739
3740 while (*s != 0)
3741   {
3742   uschar *value;
3743   uschar name[256];
3744
3745   /* \ escapes the next character, which must exist, or else
3746   the expansion fails. There's a special escape, \N, which causes
3747   copying of the subject verbatim up to the next \N. Otherwise,
3748   the escapes are the standard set. */
3749
3750   if (*s == '\\')
3751     {
3752     if (s[1] == 0)
3753       {
3754       expand_string_message = US"\\ at end of string";
3755       goto EXPAND_FAILED;
3756       }
3757
3758     if (s[1] == 'N')
3759       {
3760       uschar *t = s + 2;
3761       for (s = t; *s != 0; s++) if (*s == '\\' && s[1] == 'N') break;
3762       yield = string_cat(yield, &size, &ptr, t, s - t);
3763       if (*s != 0) s += 2;
3764       }
3765
3766     else
3767       {
3768       uschar ch[1];
3769       ch[0] = string_interpret_escape(&s);
3770       s++;
3771       yield = string_cat(yield, &size, &ptr, ch, 1);
3772       }
3773
3774     continue;
3775     }
3776
3777   /*{*/
3778   /* Anything other than $ is just copied verbatim, unless we are
3779   looking for a terminating } character. */
3780
3781   /*{*/
3782   if (ket_ends && *s == '}') break;
3783
3784   if (*s != '$' || !honour_dollar)
3785     {
3786     yield = string_cat(yield, &size, &ptr, s++, 1);
3787     continue;
3788     }
3789
3790   /* No { after the $ - must be a plain name or a number for string
3791   match variable. There has to be a fudge for variables that are the
3792   names of header fields preceded by "$header_" because header field
3793   names can contain any printing characters except space and colon.
3794   For those that don't like typing this much, "$h_" is a synonym for
3795   "$header_". A non-existent header yields a NULL value; nothing is
3796   inserted. */  /*}*/
3797
3798   if (isalpha((*(++s))))
3799     {
3800     int len;
3801     int newsize = 0;
3802
3803     s = read_name(name, sizeof(name), s, US"_");
3804
3805     /* If this is the first thing to be expanded, release the pre-allocated
3806     buffer. */
3807
3808     if (ptr == 0 && yield != NULL)
3809       {
3810       if (resetok) store_reset(yield);
3811       yield = NULL;
3812       size = 0;
3813       }
3814
3815     /* Header */
3816
3817     if (Ustrncmp(name, "h_", 2) == 0 ||
3818         Ustrncmp(name, "rh_", 3) == 0 ||
3819         Ustrncmp(name, "bh_", 3) == 0 ||
3820         Ustrncmp(name, "header_", 7) == 0 ||
3821         Ustrncmp(name, "rheader_", 8) == 0 ||
3822         Ustrncmp(name, "bheader_", 8) == 0)
3823       {
3824       BOOL want_raw = (name[0] == 'r')? TRUE : FALSE;
3825       uschar *charset = (name[0] == 'b')? NULL : headers_charset;
3826       s = read_header_name(name, sizeof(name), s);
3827       value = find_header(name, FALSE, &newsize, want_raw, charset);
3828
3829       /* If we didn't find the header, and the header contains a closing brace
3830       character, this may be a user error where the terminating colon
3831       has been omitted. Set a flag to adjust the error message in this case.
3832       But there is no error here - nothing gets inserted. */
3833
3834       if (value == NULL)
3835         {
3836         if (Ustrchr(name, '}') != NULL) malformed_header = TRUE;
3837         continue;
3838         }
3839       }
3840
3841     /* Variable */
3842
3843     else
3844       {
3845       value = find_variable(name, FALSE, skipping, &newsize);
3846       if (value == NULL)
3847         {
3848         expand_string_message =
3849           string_sprintf("unknown variable name \"%s\"", name);
3850           check_variable_error_message(name);
3851         goto EXPAND_FAILED;
3852         }
3853       }
3854
3855     /* If the data is known to be in a new buffer, newsize will be set to the
3856     size of that buffer. If this is the first thing in an expansion string,
3857     yield will be NULL; just point it at the new store instead of copying. Many
3858     expansion strings contain just one reference, so this is a useful
3859     optimization, especially for humungous headers. */
3860
3861     len = Ustrlen(value);
3862     if (yield == NULL && newsize != 0)
3863       {
3864       yield = value;
3865       size = newsize;
3866       ptr = len;
3867       }
3868     else yield = string_cat(yield, &size, &ptr, value, len);
3869
3870     continue;
3871     }
3872
3873   if (isdigit(*s))
3874     {
3875     int n;
3876     s = read_number(&n, s);
3877     if (n >= 0 && n <= expand_nmax)
3878       yield = string_cat(yield, &size, &ptr, expand_nstring[n],
3879         expand_nlength[n]);
3880     continue;
3881     }
3882
3883   /* Otherwise, if there's no '{' after $ it's an error. */             /*}*/
3884
3885   if (*s != '{')                                                        /*}*/
3886     {
3887     expand_string_message = US"$ not followed by letter, digit, or {";  /*}*/
3888     goto EXPAND_FAILED;
3889     }
3890
3891   /* After { there can be various things, but they all start with
3892   an initial word, except for a number for a string match variable. */
3893
3894   if (isdigit((*(++s))))
3895     {
3896     int n;
3897     s = read_number(&n, s);             /*{*/
3898     if (*s++ != '}')
3899       {                                 /*{*/
3900       expand_string_message = US"} expected after number";
3901       goto EXPAND_FAILED;
3902       }
3903     if (n >= 0 && n <= expand_nmax)
3904       yield = string_cat(yield, &size, &ptr, expand_nstring[n],
3905         expand_nlength[n]);
3906     continue;
3907     }
3908
3909   if (!isalpha(*s))
3910     {
3911     expand_string_message = US"letter or digit expected after ${";      /*}*/
3912     goto EXPAND_FAILED;
3913     }
3914
3915   /* Allow "-" in names to cater for substrings with negative
3916   arguments. Since we are checking for known names after { this is
3917   OK. */
3918
3919   s = read_name(name, sizeof(name), s, US"_-");
3920   item_type = chop_match(name, item_table, sizeof(item_table)/sizeof(uschar *));
3921
3922   switch(item_type)
3923     {
3924     /* Call an ACL from an expansion.  We feed data in via $acl_arg1 - $acl_arg9.
3925     If the ACL returns accept or reject we return content set by "message ="
3926     There is currently no limit on recursion; this would have us call
3927     acl_check_internal() directly and get a current level from somewhere.
3928     See also the acl expansion condition ECOND_ACL and the traditional
3929     acl modifier ACLC_ACL.
3930     Assume that the function has side-effects on the store that must be preserved.
3931     */
3932
3933     case EITEM_ACL:
3934       /* ${acl {name} {arg1}{arg2}...} */
3935       {
3936       uschar *sub[10];  /* name + arg1-arg9 (which must match number of acl_arg[]) */
3937       uschar *user_msg;
3938
3939       switch(read_subs(sub, 10, 1, &s, skipping, TRUE, US"acl", &resetok))
3940         {
3941         case 1: goto EXPAND_FAILED_CURLY;
3942         case 2:
3943         case 3: goto EXPAND_FAILED;
3944         }
3945       if (skipping) continue;
3946
3947       resetok = FALSE;
3948       switch(eval_acl(sub, sizeof(sub)/sizeof(*sub), &user_msg))
3949         {
3950         case OK:
3951         case FAIL:
3952           if (user_msg)
3953             yield = string_cat(yield, &size, &ptr, user_msg, Ustrlen(user_msg));
3954           continue;
3955
3956         case DEFER:
3957           expand_string_forcedfail = TRUE;
3958         default:
3959           expand_string_message = string_sprintf("error from acl \"%s\"", sub[0]);
3960           goto EXPAND_FAILED;
3961         }
3962       }
3963
3964     /* Handle conditionals - preserve the values of the numerical expansion
3965     variables in case they get changed by a regular expression match in the
3966     condition. If not, they retain their external settings. At the end
3967     of this "if" section, they get restored to their previous values. */
3968
3969     case EITEM_IF:
3970       {
3971       BOOL cond = FALSE;
3972       uschar *next_s;
3973       int save_expand_nmax =
3974         save_expand_strings(save_expand_nstring, save_expand_nlength);
3975
3976       while (isspace(*s)) s++;
3977       next_s = eval_condition(s, &resetok, skipping? NULL : &cond);
3978       if (next_s == NULL) goto EXPAND_FAILED;  /* message already set */
3979
3980       DEBUG(D_expand)
3981         debug_printf("condition: %.*s\n   result: %s\n", (int)(next_s - s), s,
3982           cond? "true" : "false");
3983
3984       s = next_s;
3985
3986       /* The handling of "yes" and "no" result strings is now in a separate
3987       function that is also used by ${lookup} and ${extract} and ${run}. */
3988
3989       switch(process_yesno(
3990                skipping,                     /* were previously skipping */
3991                cond,                         /* success/failure indicator */
3992                lookup_value,                 /* value to reset for string2 */
3993                &s,                           /* input pointer */
3994                &yield,                       /* output pointer */
3995                &size,                        /* output size */
3996                &ptr,                         /* output current point */
3997                US"if",                       /* condition type */
3998                &resetok))
3999         {
4000         case 1: goto EXPAND_FAILED;          /* when all is well, the */
4001         case 2: goto EXPAND_FAILED_CURLY;    /* returned value is 0 */
4002         }
4003
4004       /* Restore external setting of expansion variables for continuation
4005       at this level. */
4006
4007       restore_expand_strings(save_expand_nmax, save_expand_nstring,
4008         save_expand_nlength);
4009       continue;
4010       }
4011
4012     /* Handle database lookups unless locked out. If "skipping" is TRUE, we are
4013     expanding an internal string that isn't actually going to be used. All we
4014     need to do is check the syntax, so don't do a lookup at all. Preserve the
4015     values of the numerical expansion variables in case they get changed by a
4016     partial lookup. If not, they retain their external settings. At the end
4017     of this "lookup" section, they get restored to their previous values. */
4018
4019     case EITEM_LOOKUP:
4020       {
4021       int stype, partial, affixlen, starflags;
4022       int expand_setup = 0;
4023       int nameptr = 0;
4024       uschar *key, *filename, *affix;
4025       uschar *save_lookup_value = lookup_value;
4026       int save_expand_nmax =
4027         save_expand_strings(save_expand_nstring, save_expand_nlength);
4028
4029       if ((expand_forbid & RDO_LOOKUP) != 0)
4030         {
4031         expand_string_message = US"lookup expansions are not permitted";
4032         goto EXPAND_FAILED;
4033         }
4034
4035       /* Get the key we are to look up for single-key+file style lookups.
4036       Otherwise set the key NULL pro-tem. */
4037
4038       while (isspace(*s)) s++;
4039       if (*s == '{')                                    /*}*/
4040         {
4041         key = expand_string_internal(s+1, TRUE, &s, skipping, TRUE, &resetok);
4042         if (key == NULL) goto EXPAND_FAILED;            /*{*/
4043         if (*s++ != '}') goto EXPAND_FAILED_CURLY;
4044         while (isspace(*s)) s++;
4045         }
4046       else key = NULL;
4047
4048       /* Find out the type of database */
4049
4050       if (!isalpha(*s))
4051         {
4052         expand_string_message = US"missing lookup type";
4053         goto EXPAND_FAILED;
4054         }
4055
4056       /* The type is a string that may contain special characters of various
4057       kinds. Allow everything except space or { to appear; the actual content
4058       is checked by search_findtype_partial. */         /*}*/
4059
4060       while (*s != 0 && *s != '{' && !isspace(*s))      /*}*/
4061         {
4062         if (nameptr < sizeof(name) - 1) name[nameptr++] = *s;
4063         s++;
4064         }
4065       name[nameptr] = 0;
4066       while (isspace(*s)) s++;
4067
4068       /* Now check for the individual search type and any partial or default
4069       options. Only those types that are actually in the binary are valid. */
4070
4071       stype = search_findtype_partial(name, &partial, &affix, &affixlen,
4072         &starflags);
4073       if (stype < 0)
4074         {
4075         expand_string_message = search_error_message;
4076         goto EXPAND_FAILED;
4077         }
4078
4079       /* Check that a key was provided for those lookup types that need it,
4080       and was not supplied for those that use the query style. */
4081
4082       if (!mac_islookup(stype, lookup_querystyle|lookup_absfilequery))
4083         {
4084         if (key == NULL)
4085           {
4086           expand_string_message = string_sprintf("missing {key} for single-"
4087             "key \"%s\" lookup", name);
4088           goto EXPAND_FAILED;
4089           }
4090         }
4091       else
4092         {
4093         if (key != NULL)
4094           {
4095           expand_string_message = string_sprintf("a single key was given for "
4096             "lookup type \"%s\", which is not a single-key lookup type", name);
4097           goto EXPAND_FAILED;
4098           }
4099         }
4100
4101       /* Get the next string in brackets and expand it. It is the file name for
4102       single-key+file lookups, and the whole query otherwise. In the case of
4103       queries that also require a file name (e.g. sqlite), the file name comes
4104       first. */
4105
4106       if (*s != '{') goto EXPAND_FAILED_CURLY;
4107       filename = expand_string_internal(s+1, TRUE, &s, skipping, TRUE, &resetok);
4108       if (filename == NULL) goto EXPAND_FAILED;
4109       if (*s++ != '}') goto EXPAND_FAILED_CURLY;
4110       while (isspace(*s)) s++;
4111
4112       /* If this isn't a single-key+file lookup, re-arrange the variables
4113       to be appropriate for the search_ functions. For query-style lookups,
4114       there is just a "key", and no file name. For the special query-style +
4115       file types, the query (i.e. "key") starts with a file name. */
4116
4117       if (key == NULL)
4118         {
4119         while (isspace(*filename)) filename++;
4120         key = filename;
4121
4122         if (mac_islookup(stype, lookup_querystyle))
4123           {
4124           filename = NULL;
4125           }
4126         else
4127           {
4128           if (*filename != '/')
4129             {
4130             expand_string_message = string_sprintf(
4131               "absolute file name expected for \"%s\" lookup", name);
4132             goto EXPAND_FAILED;
4133             }
4134           while (*key != 0 && !isspace(*key)) key++;
4135           if (*key != 0) *key++ = 0;
4136           }
4137         }
4138
4139       /* If skipping, don't do the next bit - just lookup_value == NULL, as if
4140       the entry was not found. Note that there is no search_close() function.
4141       Files are left open in case of re-use. At suitable places in higher logic,
4142       search_tidyup() is called to tidy all open files. This can save opening
4143       the same file several times. However, files may also get closed when
4144       others are opened, if too many are open at once. The rule is that a
4145       handle should not be used after a second search_open().
4146
4147       Request that a partial search sets up $1 and maybe $2 by passing
4148       expand_setup containing zero. If its value changes, reset expand_nmax,
4149       since new variables will have been set. Note that at the end of this
4150       "lookup" section, the old numeric variables are restored. */
4151
4152       if (skipping)
4153         lookup_value = NULL;
4154       else
4155         {
4156         void *handle = search_open(filename, stype, 0, NULL, NULL);
4157         if (handle == NULL)
4158           {
4159           expand_string_message = search_error_message;
4160           goto EXPAND_FAILED;
4161           }
4162         lookup_value = search_find(handle, filename, key, partial, affix,
4163           affixlen, starflags, &expand_setup);
4164         if (search_find_defer)
4165           {
4166           expand_string_message =
4167             string_sprintf("lookup of \"%s\" gave DEFER: %s",
4168               string_printing2(key, FALSE), search_error_message);
4169           goto EXPAND_FAILED;
4170           }
4171         if (expand_setup > 0) expand_nmax = expand_setup;
4172         }
4173
4174       /* The handling of "yes" and "no" result strings is now in a separate
4175       function that is also used by ${if} and ${extract}. */
4176
4177       switch(process_yesno(
4178                skipping,                     /* were previously skipping */
4179                lookup_value != NULL,         /* success/failure indicator */
4180                save_lookup_value,            /* value to reset for string2 */
4181                &s,                           /* input pointer */
4182                &yield,                       /* output pointer */
4183                &size,                        /* output size */
4184                &ptr,                         /* output current point */
4185                US"lookup",                   /* condition type */
4186                &resetok))
4187         {
4188         case 1: goto EXPAND_FAILED;          /* when all is well, the */
4189         case 2: goto EXPAND_FAILED_CURLY;    /* returned value is 0 */
4190         }
4191
4192       /* Restore external setting of expansion variables for carrying on
4193       at this level, and continue. */
4194
4195       restore_expand_strings(save_expand_nmax, save_expand_nstring,
4196         save_expand_nlength);
4197       continue;
4198       }
4199
4200     /* If Perl support is configured, handle calling embedded perl subroutines,
4201     unless locked out at this time. Syntax is ${perl{sub}} or ${perl{sub}{arg}}
4202     or ${perl{sub}{arg1}{arg2}} or up to a maximum of EXIM_PERL_MAX_ARGS
4203     arguments (defined below). */
4204
4205     #define EXIM_PERL_MAX_ARGS 8
4206
4207     case EITEM_PERL:
4208     #ifndef EXIM_PERL
4209     expand_string_message = US"\"${perl\" encountered, but this facility "      /*}*/
4210       "is not included in this binary";
4211     goto EXPAND_FAILED;
4212
4213     #else   /* EXIM_PERL */
4214       {
4215       uschar *sub_arg[EXIM_PERL_MAX_ARGS + 2];
4216       uschar *new_yield;
4217
4218       if ((expand_forbid & RDO_PERL) != 0)
4219         {
4220         expand_string_message = US"Perl calls are not permitted";
4221         goto EXPAND_FAILED;
4222         }
4223
4224       switch(read_subs(sub_arg, EXIM_PERL_MAX_ARGS + 1, 1, &s, skipping, TRUE,
4225            US"perl", &resetok))
4226         {
4227         case 1: goto EXPAND_FAILED_CURLY;
4228         case 2:
4229         case 3: goto EXPAND_FAILED;
4230         }
4231
4232       /* If skipping, we don't actually do anything */
4233
4234       if (skipping) continue;
4235
4236       /* Start the interpreter if necessary */
4237
4238       if (!opt_perl_started)
4239         {
4240         uschar *initerror;
4241         if (opt_perl_startup == NULL)
4242           {
4243           expand_string_message = US"A setting of perl_startup is needed when "
4244             "using the Perl interpreter";
4245           goto EXPAND_FAILED;
4246           }
4247         DEBUG(D_any) debug_printf("Starting Perl interpreter\n");
4248         initerror = init_perl(opt_perl_startup);
4249         if (initerror != NULL)
4250           {
4251           expand_string_message =
4252             string_sprintf("error in perl_startup code: %s\n", initerror);
4253           goto EXPAND_FAILED;
4254           }
4255         opt_perl_started = TRUE;
4256         }
4257
4258       /* Call the function */
4259
4260       sub_arg[EXIM_PERL_MAX_ARGS + 1] = NULL;
4261       new_yield = call_perl_cat(yield, &size, &ptr, &expand_string_message,
4262         sub_arg[0], sub_arg + 1);
4263
4264       /* NULL yield indicates failure; if the message pointer has been set to
4265       NULL, the yield was undef, indicating a forced failure. Otherwise the
4266       message will indicate some kind of Perl error. */
4267
4268       if (new_yield == NULL)
4269         {
4270         if (expand_string_message == NULL)
4271           {
4272           expand_string_message =
4273             string_sprintf("Perl subroutine \"%s\" returned undef to force "
4274               "failure", sub_arg[0]);
4275           expand_string_forcedfail = TRUE;
4276           }
4277         goto EXPAND_FAILED;
4278         }
4279
4280       /* Yield succeeded. Ensure forcedfail is unset, just in case it got
4281       set during a callback from Perl. */
4282
4283       expand_string_forcedfail = FALSE;
4284       yield = new_yield;
4285       continue;
4286       }
4287     #endif /* EXIM_PERL */
4288
4289     /* Transform email address to "prvs" scheme to use
4290        as BATV-signed return path */
4291
4292     case EITEM_PRVS:
4293       {
4294       uschar *sub_arg[3];
4295       uschar *p,*domain;
4296
4297       switch(read_subs(sub_arg, 3, 2, &s, skipping, TRUE, US"prvs", &resetok))
4298         {
4299         case 1: goto EXPAND_FAILED_CURLY;
4300         case 2:
4301         case 3: goto EXPAND_FAILED;
4302         }
4303
4304       /* If skipping, we don't actually do anything */
4305       if (skipping) continue;
4306
4307       /* sub_arg[0] is the address */
4308       domain = Ustrrchr(sub_arg[0],'@');
4309       if ( (domain == NULL) || (domain == sub_arg[0]) || (Ustrlen(domain) == 1) )
4310         {
4311         expand_string_message = US"prvs first argument must be a qualified email address";
4312         goto EXPAND_FAILED;
4313         }
4314
4315       /* Calculate the hash. The second argument must be a single-digit
4316       key number, or unset. */
4317
4318       if (sub_arg[2] != NULL &&
4319           (!isdigit(sub_arg[2][0]) || sub_arg[2][1] != 0))
4320         {
4321         expand_string_message = US"prvs second argument must be a single digit";
4322         goto EXPAND_FAILED;
4323         }
4324
4325       p = prvs_hmac_sha1(sub_arg[0],sub_arg[1],sub_arg[2],prvs_daystamp(7));
4326       if (p == NULL)
4327         {
4328         expand_string_message = US"prvs hmac-sha1 conversion failed";
4329         goto EXPAND_FAILED;
4330         }
4331
4332       /* Now separate the domain from the local part */
4333       *domain++ = '\0';
4334
4335       yield = string_cat(yield,&size,&ptr,US"prvs=",5);
4336       string_cat(yield,&size,&ptr,(sub_arg[2] != NULL) ? sub_arg[2] : US"0", 1);
4337       string_cat(yield,&size,&ptr,prvs_daystamp(7),3);
4338       string_cat(yield,&size,&ptr,p,6);
4339       string_cat(yield,&size,&ptr,US"=",1);
4340       string_cat(yield,&size,&ptr,sub_arg[0],Ustrlen(sub_arg[0]));
4341       string_cat(yield,&size,&ptr,US"@",1);
4342       string_cat(yield,&size,&ptr,domain,Ustrlen(domain));
4343
4344       continue;
4345       }
4346
4347     /* Check a prvs-encoded address for validity */
4348
4349     case EITEM_PRVSCHECK:
4350       {
4351       uschar *sub_arg[3];
4352       int mysize = 0, myptr = 0;
4353       const pcre *re;
4354       uschar *p;
4355
4356       /* TF: Ugliness: We want to expand parameter 1 first, then set
4357          up expansion variables that are used in the expansion of
4358          parameter 2. So we clone the string for the first
4359          expansion, where we only expand parameter 1.
4360
4361          PH: Actually, that isn't necessary. The read_subs() function is
4362          designed to work this way for the ${if and ${lookup expansions. I've
4363          tidied the code.
4364       */
4365
4366       /* Reset expansion variables */
4367       prvscheck_result = NULL;
4368       prvscheck_address = NULL;
4369       prvscheck_keynum = NULL;
4370
4371       switch(read_subs(sub_arg, 1, 1, &s, skipping, FALSE, US"prvs", &resetok))
4372         {
4373         case 1: goto EXPAND_FAILED_CURLY;
4374         case 2:
4375         case 3: goto EXPAND_FAILED;
4376         }
4377
4378       re = regex_must_compile(US"^prvs\\=([0-9])([0-9]{3})([A-F0-9]{6})\\=(.+)\\@(.+)$",
4379                               TRUE,FALSE);
4380
4381       if (regex_match_and_setup(re,sub_arg[0],0,-1))
4382         {
4383         uschar *local_part = string_copyn(expand_nstring[4],expand_nlength[4]);
4384         uschar *key_num = string_copyn(expand_nstring[1],expand_nlength[1]);
4385         uschar *daystamp = string_copyn(expand_nstring[2],expand_nlength[2]);
4386         uschar *hash = string_copyn(expand_nstring[3],expand_nlength[3]);
4387         uschar *domain = string_copyn(expand_nstring[5],expand_nlength[5]);
4388
4389         DEBUG(D_expand) debug_printf("prvscheck localpart: %s\n", local_part);
4390         DEBUG(D_expand) debug_printf("prvscheck key number: %s\n", key_num);
4391         DEBUG(D_expand) debug_printf("prvscheck daystamp: %s\n", daystamp);
4392         DEBUG(D_expand) debug_printf("prvscheck hash: %s\n", hash);
4393         DEBUG(D_expand) debug_printf("prvscheck domain: %s\n", domain);
4394
4395         /* Set up expansion variables */
4396         prvscheck_address = string_cat(NULL, &mysize, &myptr, local_part, Ustrlen(local_part));
4397         string_cat(prvscheck_address,&mysize,&myptr,US"@",1);
4398         string_cat(prvscheck_address,&mysize,&myptr,domain,Ustrlen(domain));
4399         prvscheck_address[myptr] = '\0';
4400         prvscheck_keynum = string_copy(key_num);
4401
4402         /* Now expand the second argument */
4403         switch(read_subs(sub_arg, 1, 1, &s, skipping, FALSE, US"prvs", &resetok))
4404           {
4405           case 1: goto EXPAND_FAILED_CURLY;
4406           case 2:
4407           case 3: goto EXPAND_FAILED;
4408           }
4409
4410         /* Now we have the key and can check the address. */
4411
4412         p = prvs_hmac_sha1(prvscheck_address, sub_arg[0], prvscheck_keynum,
4413           daystamp);
4414
4415         if (p == NULL)
4416           {
4417           expand_string_message = US"hmac-sha1 conversion failed";
4418           goto EXPAND_FAILED;
4419           }
4420
4421         DEBUG(D_expand) debug_printf("prvscheck: received hash is %s\n", hash);
4422         DEBUG(D_expand) debug_printf("prvscheck:      own hash is %s\n", p);
4423
4424         if (Ustrcmp(p,hash) == 0)
4425           {
4426           /* Success, valid BATV address. Now check the expiry date. */
4427           uschar *now = prvs_daystamp(0);
4428           unsigned int inow = 0,iexpire = 1;
4429
4430           (void)sscanf(CS now,"%u",&inow);
4431           (void)sscanf(CS daystamp,"%u",&iexpire);
4432
4433           /* When "iexpire" is < 7, a "flip" has occured.
4434              Adjust "inow" accordingly. */
4435           if ( (iexpire < 7) && (inow >= 993) ) inow = 0;
4436
4437           if (iexpire >= inow)
4438             {
4439             prvscheck_result = US"1";
4440             DEBUG(D_expand) debug_printf("prvscheck: success, $pvrs_result set to 1\n");
4441             }
4442             else
4443             {
4444             prvscheck_result = NULL;
4445             DEBUG(D_expand) debug_printf("prvscheck: signature expired, $pvrs_result unset\n");
4446             }
4447           }
4448         else
4449           {
4450           prvscheck_result = NULL;
4451           DEBUG(D_expand) debug_printf("prvscheck: hash failure, $pvrs_result unset\n");
4452           }
4453
4454         /* Now expand the final argument. We leave this till now so that
4455         it can include $prvscheck_result. */
4456
4457         switch(read_subs(sub_arg, 1, 0, &s, skipping, TRUE, US"prvs", &resetok))
4458           {
4459           case 1: goto EXPAND_FAILED_CURLY;
4460           case 2:
4461           case 3: goto EXPAND_FAILED;
4462           }
4463
4464         if (sub_arg[0] == NULL || *sub_arg[0] == '\0')
4465           yield = string_cat(yield,&size,&ptr,prvscheck_address,Ustrlen(prvscheck_address));
4466         else
4467           yield = string_cat(yield,&size,&ptr,sub_arg[0],Ustrlen(sub_arg[0]));
4468
4469         /* Reset the "internal" variables afterwards, because they are in
4470         dynamic store that will be reclaimed if the expansion succeeded. */
4471
4472         prvscheck_address = NULL;
4473         prvscheck_keynum = NULL;
4474         }
4475       else
4476         {
4477         /* Does not look like a prvs encoded address, return the empty string.
4478            We need to make sure all subs are expanded first, so as to skip over
4479            the entire item. */
4480
4481         switch(read_subs(sub_arg, 2, 1, &s, skipping, TRUE, US"prvs", &resetok))
4482           {
4483           case 1: goto EXPAND_FAILED_CURLY;
4484           case 2:
4485           case 3: goto EXPAND_FAILED;
4486           }
4487         }
4488
4489       continue;
4490       }
4491
4492     /* Handle "readfile" to insert an entire file */
4493
4494     case EITEM_READFILE:
4495       {
4496       FILE *f;
4497       uschar *sub_arg[2];
4498
4499       if ((expand_forbid & RDO_READFILE) != 0)
4500         {
4501         expand_string_message = US"file insertions are not permitted";
4502         goto EXPAND_FAILED;
4503         }
4504
4505       switch(read_subs(sub_arg, 2, 1, &s, skipping, TRUE, US"readfile", &resetok))
4506         {
4507         case 1: goto EXPAND_FAILED_CURLY;
4508         case 2:
4509         case 3: goto EXPAND_FAILED;
4510         }
4511
4512       /* If skipping, we don't actually do anything */
4513
4514       if (skipping) continue;
4515
4516       /* Open the file and read it */
4517
4518       f = Ufopen(sub_arg[0], "rb");
4519       if (f == NULL)
4520         {
4521         expand_string_message = string_open_failed(errno, "%s", sub_arg[0]);
4522         goto EXPAND_FAILED;
4523         }
4524
4525       yield = cat_file(f, yield, &size, &ptr, sub_arg[1]);
4526       (void)fclose(f);
4527       continue;
4528       }
4529
4530     /* Handle "readsocket" to insert data from a Unix domain socket */
4531
4532     case EITEM_READSOCK:
4533       {
4534       int fd;
4535       int timeout = 5;
4536       int save_ptr = ptr;
4537       FILE *f;
4538       struct sockaddr_un sockun;         /* don't call this "sun" ! */
4539       uschar *arg;
4540       uschar *sub_arg[4];
4541
4542       if ((expand_forbid & RDO_READSOCK) != 0)
4543         {
4544         expand_string_message = US"socket insertions are not permitted";
4545         goto EXPAND_FAILED;
4546         }
4547
4548       /* Read up to 4 arguments, but don't do the end of item check afterwards,
4549       because there may be a string for expansion on failure. */
4550
4551       switch(read_subs(sub_arg, 4, 2, &s, skipping, FALSE, US"readsocket", &resetok))
4552         {
4553         case 1: goto EXPAND_FAILED_CURLY;
4554         case 2:                             /* Won't occur: no end check */
4555         case 3: goto EXPAND_FAILED;
4556         }
4557
4558       /* Sort out timeout, if given */
4559
4560       if (sub_arg[2] != NULL)
4561         {
4562         timeout = readconf_readtime(sub_arg[2], 0, FALSE);
4563         if (timeout < 0)
4564           {
4565           expand_string_message = string_sprintf("bad time value %s",
4566             sub_arg[2]);
4567           goto EXPAND_FAILED;
4568           }
4569         }
4570       else sub_arg[3] = NULL;                     /* No eol if no timeout */
4571
4572       /* If skipping, we don't actually do anything. Otherwise, arrange to
4573       connect to either an IP or a Unix socket. */
4574
4575       if (!skipping)
4576         {
4577         /* Handle an IP (internet) domain */
4578
4579         if (Ustrncmp(sub_arg[0], "inet:", 5) == 0)
4580           {
4581           int port;
4582           uschar *server_name = sub_arg[0] + 5;
4583           uschar *port_name = Ustrrchr(server_name, ':');
4584
4585           /* Sort out the port */
4586
4587           if (port_name == NULL)
4588             {
4589             expand_string_message =
4590               string_sprintf("missing port for readsocket %s", sub_arg[0]);
4591             goto EXPAND_FAILED;
4592             }
4593           *port_name++ = 0;           /* Terminate server name */
4594
4595           if (isdigit(*port_name))
4596             {
4597             uschar *end;
4598             port = Ustrtol(port_name, &end, 0);
4599             if (end != port_name + Ustrlen(port_name))
4600               {
4601               expand_string_message =
4602                 string_sprintf("invalid port number %s", port_name);
4603               goto EXPAND_FAILED;
4604               }
4605             }
4606           else
4607             {
4608             struct servent *service_info = getservbyname(CS port_name, "tcp");
4609             if (service_info == NULL)
4610               {
4611               expand_string_message = string_sprintf("unknown port \"%s\"",
4612                 port_name);
4613               goto EXPAND_FAILED;
4614               }
4615             port = ntohs(service_info->s_port);
4616             }
4617
4618           if ((fd = ip_connectedsocket(SOCK_STREAM, server_name, port, port,
4619                   timeout, NULL, &expand_string_message)) < 0)
4620               goto SOCK_FAIL;
4621           }
4622
4623         /* Handle a Unix domain socket */
4624
4625         else
4626           {
4627           int rc;
4628           if ((fd = socket(PF_UNIX, SOCK_STREAM, 0)) == -1)
4629             {
4630             expand_string_message = string_sprintf("failed to create socket: %s",
4631               strerror(errno));
4632             goto SOCK_FAIL;
4633             }
4634
4635           sockun.sun_family = AF_UNIX;
4636           sprintf(sockun.sun_path, "%.*s", (int)(sizeof(sockun.sun_path)-1),
4637             sub_arg[0]);
4638
4639           sigalrm_seen = FALSE;
4640           alarm(timeout);
4641           rc = connect(fd, (struct sockaddr *)(&sockun), sizeof(sockun));
4642           alarm(0);
4643           if (sigalrm_seen)
4644             {
4645             expand_string_message = US "socket connect timed out";
4646             goto SOCK_FAIL;
4647             }
4648           if (rc < 0)
4649             {
4650             expand_string_message = string_sprintf("failed to connect to socket "
4651               "%s: %s", sub_arg[0], strerror(errno));
4652             goto SOCK_FAIL;
4653             }
4654           }
4655
4656         DEBUG(D_expand) debug_printf("connected to socket %s\n", sub_arg[0]);
4657
4658         /* Write the request string, if not empty */
4659
4660         if (sub_arg[1][0] != 0)
4661           {
4662           int len = Ustrlen(sub_arg[1]);
4663           DEBUG(D_expand) debug_printf("writing \"%s\" to socket\n",
4664             sub_arg[1]);
4665           if (write(fd, sub_arg[1], len) != len)
4666             {
4667             expand_string_message = string_sprintf("request write to socket "
4668               "failed: %s", strerror(errno));
4669             goto SOCK_FAIL;
4670             }
4671           }
4672
4673         /* Shut down the sending side of the socket. This helps some servers to
4674         recognise that it is their turn to do some work. Just in case some
4675         system doesn't have this function, make it conditional. */
4676
4677         #ifdef SHUT_WR
4678         shutdown(fd, SHUT_WR);
4679         #endif
4680
4681         /* Now we need to read from the socket, under a timeout. The function
4682         that reads a file can be used. */
4683
4684         f = fdopen(fd, "rb");
4685         sigalrm_seen = FALSE;
4686         alarm(timeout);
4687         yield = cat_file(f, yield, &size, &ptr, sub_arg[3]);
4688         alarm(0);
4689         (void)fclose(f);
4690
4691         /* After a timeout, we restore the pointer in the result, that is,
4692         make sure we add nothing from the socket. */
4693
4694         if (sigalrm_seen)
4695           {
4696           ptr = save_ptr;
4697           expand_string_message = US "socket read timed out";
4698           goto SOCK_FAIL;
4699           }
4700         }
4701
4702       /* The whole thing has worked (or we were skipping). If there is a
4703       failure string following, we need to skip it. */
4704
4705       if (*s == '{')
4706         {
4707         if (expand_string_internal(s+1, TRUE, &s, TRUE, TRUE, &resetok) == NULL)
4708           goto EXPAND_FAILED;
4709         if (*s++ != '}') goto EXPAND_FAILED_CURLY;
4710         while (isspace(*s)) s++;
4711         }
4712       if (*s++ != '}') goto EXPAND_FAILED_CURLY;
4713       continue;
4714
4715       /* Come here on failure to create socket, connect socket, write to the
4716       socket, or timeout on reading. If another substring follows, expand and
4717       use it. Otherwise, those conditions give expand errors. */
4718
4719       SOCK_FAIL:
4720       if (*s != '{') goto EXPAND_FAILED;
4721       DEBUG(D_any) debug_printf("%s\n", expand_string_message);
4722       arg = expand_string_internal(s+1, TRUE, &s, FALSE, TRUE, &resetok);
4723       if (arg == NULL) goto EXPAND_FAILED;
4724       yield = string_cat(yield, &size, &ptr, arg, Ustrlen(arg));
4725       if (*s++ != '}') goto EXPAND_FAILED_CURLY;
4726       while (isspace(*s)) s++;
4727       if (*s++ != '}') goto EXPAND_FAILED_CURLY;
4728       continue;
4729       }
4730
4731     /* Handle "run" to execute a program. */
4732
4733     case EITEM_RUN:
4734       {
4735       FILE *f;
4736       uschar *arg;
4737       uschar **argv;
4738       pid_t pid;
4739       int fd_in, fd_out;
4740       int lsize = 0;
4741       int lptr = 0;
4742
4743       if ((expand_forbid & RDO_RUN) != 0)
4744         {
4745         expand_string_message = US"running a command is not permitted";
4746         goto EXPAND_FAILED;
4747         }
4748
4749       while (isspace(*s)) s++;
4750       if (*s != '{') goto EXPAND_FAILED_CURLY;
4751       arg = expand_string_internal(s+1, TRUE, &s, skipping, TRUE, &resetok);
4752       if (arg == NULL) goto EXPAND_FAILED;
4753       while (isspace(*s)) s++;
4754       if (*s++ != '}') goto EXPAND_FAILED_CURLY;
4755
4756       if (skipping)   /* Just pretend it worked when we're skipping */
4757         {
4758         runrc = 0;
4759         }
4760       else
4761         {
4762         if (!transport_set_up_command(&argv,    /* anchor for arg list */
4763             arg,                                /* raw command */
4764             FALSE,                              /* don't expand the arguments */
4765             0,                                  /* not relevant when... */
4766             NULL,                               /* no transporting address */
4767             US"${run} expansion",               /* for error messages */
4768             &expand_string_message))            /* where to put error message */
4769           {
4770           goto EXPAND_FAILED;
4771           }
4772
4773         /* Create the child process, making it a group leader. */
4774
4775         pid = child_open(argv, NULL, 0077, &fd_in, &fd_out, TRUE);
4776
4777         if (pid < 0)
4778           {
4779           expand_string_message =
4780             string_sprintf("couldn't create child process: %s", strerror(errno));
4781           goto EXPAND_FAILED;
4782           }
4783
4784         /* Nothing is written to the standard input. */
4785
4786         (void)close(fd_in);
4787
4788         /* Read the pipe to get the command's output into $value (which is kept
4789         in lookup_value). Read during execution, so that if the output exceeds
4790         the OS pipe buffer limit, we don't block forever. */
4791
4792         f = fdopen(fd_out, "rb");
4793         sigalrm_seen = FALSE;
4794         alarm(60);
4795         lookup_value = cat_file(f, lookup_value, &lsize, &lptr, NULL);
4796         alarm(0);
4797         (void)fclose(f);
4798
4799         /* Wait for the process to finish, applying the timeout, and inspect its
4800         return code for serious disasters. Simple non-zero returns are passed on.
4801         */
4802
4803         if (sigalrm_seen == TRUE || (runrc = child_close(pid, 30)) < 0)
4804           {
4805           if (sigalrm_seen == TRUE || runrc == -256)
4806             {
4807             expand_string_message = string_sprintf("command timed out");
4808             killpg(pid, SIGKILL);       /* Kill the whole process group */
4809             }
4810
4811           else if (runrc == -257)
4812             expand_string_message = string_sprintf("wait() failed: %s",
4813               strerror(errno));
4814
4815           else
4816             expand_string_message = string_sprintf("command killed by signal %d",
4817               -runrc);
4818
4819           goto EXPAND_FAILED;
4820           }
4821         }
4822
4823       /* Process the yes/no strings; $value may be useful in both cases */
4824
4825       switch(process_yesno(
4826                skipping,                     /* were previously skipping */
4827                runrc == 0,                   /* success/failure indicator */
4828                lookup_value,                 /* value to reset for string2 */
4829                &s,                           /* input pointer */
4830                &yield,                       /* output pointer */
4831                &size,                        /* output size */
4832                &ptr,                         /* output current point */
4833                US"run",                      /* condition type */
4834                &resetok))
4835         {
4836         case 1: goto EXPAND_FAILED;          /* when all is well, the */
4837         case 2: goto EXPAND_FAILED_CURLY;    /* returned value is 0 */
4838         }
4839
4840       continue;
4841       }
4842
4843     /* Handle character translation for "tr" */
4844
4845     case EITEM_TR:
4846       {
4847       int oldptr = ptr;
4848       int o2m;
4849       uschar *sub[3];
4850
4851       switch(read_subs(sub, 3, 3, &s, skipping, TRUE, US"tr", &resetok))
4852         {
4853         case 1: goto EXPAND_FAILED_CURLY;
4854         case 2:
4855         case 3: goto EXPAND_FAILED;
4856         }
4857
4858       yield = string_cat(yield, &size, &ptr, sub[0], Ustrlen(sub[0]));
4859       o2m = Ustrlen(sub[2]) - 1;
4860
4861       if (o2m >= 0) for (; oldptr < ptr; oldptr++)
4862         {
4863         uschar *m = Ustrrchr(sub[1], yield[oldptr]);
4864         if (m != NULL)
4865           {
4866           int o = m - sub[1];
4867           yield[oldptr] = sub[2][(o < o2m)? o : o2m];
4868           }
4869         }
4870
4871       continue;
4872       }
4873
4874     /* Handle "hash", "length", "nhash", and "substr" when they are given with
4875     expanded arguments. */
4876
4877     case EITEM_HASH:
4878     case EITEM_LENGTH:
4879     case EITEM_NHASH:
4880     case EITEM_SUBSTR:
4881       {
4882       int i;
4883       int len;
4884       uschar *ret;
4885       int val[2] = { 0, -1 };
4886       uschar *sub[3];
4887
4888       /* "length" takes only 2 arguments whereas the others take 2 or 3.
4889       Ensure that sub[2] is set in the ${length } case. */
4890
4891       sub[2] = NULL;
4892       switch(read_subs(sub, (item_type == EITEM_LENGTH)? 2:3, 2, &s, skipping,
4893              TRUE, name, &resetok))
4894         {
4895         case 1: goto EXPAND_FAILED_CURLY;
4896         case 2:
4897         case 3: goto EXPAND_FAILED;
4898         }
4899
4900       /* Juggle the arguments if there are only two of them: always move the
4901       string to the last position and make ${length{n}{str}} equivalent to
4902       ${substr{0}{n}{str}}. See the defaults for val[] above. */
4903
4904       if (sub[2] == NULL)
4905         {
4906         sub[2] = sub[1];
4907         sub[1] = NULL;
4908         if (item_type == EITEM_LENGTH)
4909           {
4910           sub[1] = sub[0];
4911           sub[0] = NULL;
4912           }
4913         }
4914
4915       for (i = 0; i < 2; i++)
4916         {
4917         if (sub[i] == NULL) continue;
4918         val[i] = (int)Ustrtol(sub[i], &ret, 10);
4919         if (*ret != 0 || (i != 0 && val[i] < 0))
4920           {
4921           expand_string_message = string_sprintf("\"%s\" is not a%s number "
4922             "(in \"%s\" expansion)", sub[i], (i != 0)? " positive" : "", name);
4923           goto EXPAND_FAILED;
4924           }
4925         }
4926
4927       ret =
4928         (item_type == EITEM_HASH)?
4929           compute_hash(sub[2], val[0], val[1], &len) :
4930         (item_type == EITEM_NHASH)?
4931           compute_nhash(sub[2], val[0], val[1], &len) :
4932           extract_substr(sub[2], val[0], val[1], &len);
4933
4934       if (ret == NULL) goto EXPAND_FAILED;
4935       yield = string_cat(yield, &size, &ptr, ret, len);
4936       continue;
4937       }
4938
4939     /* Handle HMAC computation: ${hmac{<algorithm>}{<secret>}{<text>}}
4940     This code originally contributed by Steve Haslam. It currently supports
4941     the use of MD5 and SHA-1 hashes.
4942
4943     We need some workspace that is large enough to handle all the supported
4944     hash types. Use macros to set the sizes rather than be too elaborate. */
4945
4946     #define MAX_HASHLEN      20
4947     #define MAX_HASHBLOCKLEN 64
4948
4949     case EITEM_HMAC:
4950       {
4951       uschar *sub[3];
4952       md5 md5_base;
4953       sha1 sha1_base;
4954       void *use_base;
4955       int type, i;
4956       int hashlen;      /* Number of octets for the hash algorithm's output */
4957       int hashblocklen; /* Number of octets the hash algorithm processes */
4958       uschar *keyptr, *p;
4959       unsigned int keylen;
4960
4961       uschar keyhash[MAX_HASHLEN];
4962       uschar innerhash[MAX_HASHLEN];
4963       uschar finalhash[MAX_HASHLEN];
4964       uschar finalhash_hex[2*MAX_HASHLEN];
4965       uschar innerkey[MAX_HASHBLOCKLEN];
4966       uschar outerkey[MAX_HASHBLOCKLEN];
4967
4968       switch (read_subs(sub, 3, 3, &s, skipping, TRUE, name, &resetok))
4969         {
4970         case 1: goto EXPAND_FAILED_CURLY;
4971         case 2:
4972         case 3: goto EXPAND_FAILED;
4973         }
4974
4975       if (Ustrcmp(sub[0], "md5") == 0)
4976         {
4977         type = HMAC_MD5;
4978         use_base = &md5_base;
4979         hashlen = 16;
4980         hashblocklen = 64;
4981         }
4982       else if (Ustrcmp(sub[0], "sha1") == 0)
4983         {
4984         type = HMAC_SHA1;
4985         use_base = &sha1_base;
4986         hashlen = 20;
4987         hashblocklen = 64;
4988         }
4989       else
4990         {
4991         expand_string_message =
4992           string_sprintf("hmac algorithm \"%s\" is not recognised", sub[0]);
4993         goto EXPAND_FAILED;
4994         }
4995
4996       keyptr = sub[1];
4997       keylen = Ustrlen(keyptr);
4998
4999       /* If the key is longer than the hash block length, then hash the key
5000       first */
5001
5002       if (keylen > hashblocklen)
5003         {
5004         chash_start(type, use_base);
5005         chash_end(type, use_base, keyptr, keylen, keyhash);
5006         keyptr = keyhash;
5007         keylen = hashlen;
5008         }
5009
5010       /* Now make the inner and outer key values */
5011
5012       memset(innerkey, 0x36, hashblocklen);
5013       memset(outerkey, 0x5c, hashblocklen);
5014
5015       for (i = 0; i < keylen; i++)
5016         {
5017         innerkey[i] ^= keyptr[i];
5018         outerkey[i] ^= keyptr[i];
5019         }
5020
5021       /* Now do the hashes */
5022
5023       chash_start(type, use_base);
5024       chash_mid(type, use_base, innerkey);
5025       chash_end(type, use_base, sub[2], Ustrlen(sub[2]), innerhash);
5026
5027       chash_start(type, use_base);
5028       chash_mid(type, use_base, outerkey);
5029       chash_end(type, use_base, innerhash, hashlen, finalhash);
5030
5031       /* Encode the final hash as a hex string */
5032
5033       p = finalhash_hex;
5034       for (i = 0; i < hashlen; i++)
5035         {
5036         *p++ = hex_digits[(finalhash[i] & 0xf0) >> 4];
5037         *p++ = hex_digits[finalhash[i] & 0x0f];
5038         }
5039
5040       DEBUG(D_any) debug_printf("HMAC[%s](%.*s,%.*s)=%.*s\n", sub[0],
5041         (int)keylen, keyptr, Ustrlen(sub[2]), sub[2], hashlen*2, finalhash_hex);
5042
5043       yield = string_cat(yield, &size, &ptr, finalhash_hex, hashlen*2);
5044       }
5045
5046     continue;
5047
5048     /* Handle global substitution for "sg" - like Perl's s/xxx/yyy/g operator.
5049     We have to save the numerical variables and restore them afterwards. */
5050
5051     case EITEM_SG:
5052       {
5053       const pcre *re;
5054       int moffset, moffsetextra, slen;
5055       int roffset;
5056       int emptyopt;
5057       const uschar *rerror;
5058       uschar *subject;
5059       uschar *sub[3];
5060       int save_expand_nmax =
5061         save_expand_strings(save_expand_nstring, save_expand_nlength);
5062
5063       switch(read_subs(sub, 3, 3, &s, skipping, TRUE, US"sg", &resetok))
5064         {
5065         case 1: goto EXPAND_FAILED_CURLY;
5066         case 2:
5067         case 3: goto EXPAND_FAILED;
5068         }
5069
5070       /* Compile the regular expression */
5071
5072       re = pcre_compile(CS sub[1], PCRE_COPT, (const char **)&rerror, &roffset,
5073         NULL);
5074
5075       if (re == NULL)
5076         {
5077         expand_string_message = string_sprintf("regular expression error in "
5078           "\"%s\": %s at offset %d", sub[1], rerror, roffset);
5079         goto EXPAND_FAILED;
5080         }
5081
5082       /* Now run a loop to do the substitutions as often as necessary. It ends
5083       when there are no more matches. Take care over matches of the null string;
5084       do the same thing as Perl does. */
5085
5086       subject = sub[0];
5087       slen = Ustrlen(sub[0]);
5088       moffset = moffsetextra = 0;
5089       emptyopt = 0;
5090
5091       for (;;)
5092         {
5093         int ovector[3*(EXPAND_MAXN+1)];
5094         int n = pcre_exec(re, NULL, CS subject, slen, moffset + moffsetextra,
5095           PCRE_EOPT | emptyopt, ovector, sizeof(ovector)/sizeof(int));
5096         int nn;
5097         uschar *insert;
5098
5099         /* No match - if we previously set PCRE_NOTEMPTY after a null match, this
5100         is not necessarily the end. We want to repeat the match from one
5101         character further along, but leaving the basic offset the same (for
5102         copying below). We can't be at the end of the string - that was checked
5103         before setting PCRE_NOTEMPTY. If PCRE_NOTEMPTY is not set, we are
5104         finished; copy the remaining string and end the loop. */
5105
5106         if (n < 0)
5107           {
5108           if (emptyopt != 0)
5109             {
5110             moffsetextra = 1;
5111             emptyopt = 0;
5112             continue;
5113             }
5114           yield = string_cat(yield, &size, &ptr, subject+moffset, slen-moffset);
5115           break;
5116           }
5117
5118         /* Match - set up for expanding the replacement. */
5119
5120         if (n == 0) n = EXPAND_MAXN + 1;
5121         expand_nmax = 0;
5122         for (nn = 0; nn < n*2; nn += 2)
5123           {
5124           expand_nstring[expand_nmax] = subject + ovector[nn];
5125           expand_nlength[expand_nmax++] = ovector[nn+1] - ovector[nn];
5126           }
5127         expand_nmax--;
5128
5129         /* Copy the characters before the match, plus the expanded insertion. */
5130
5131         yield = string_cat(yield, &size, &ptr, subject + moffset,
5132           ovector[0] - moffset);
5133         insert = expand_string(sub[2]);
5134         if (insert == NULL) goto EXPAND_FAILED;
5135         yield = string_cat(yield, &size, &ptr, insert, Ustrlen(insert));
5136
5137         moffset = ovector[1];
5138         moffsetextra = 0;
5139         emptyopt = 0;
5140
5141         /* If we have matched an empty string, first check to see if we are at
5142         the end of the subject. If so, the loop is over. Otherwise, mimic
5143         what Perl's /g options does. This turns out to be rather cunning. First
5144         we set PCRE_NOTEMPTY and PCRE_ANCHORED and try the match a non-empty
5145         string at the same point. If this fails (picked up above) we advance to
5146         the next character. */
5147
5148         if (ovector[0] == ovector[1])
5149           {
5150           if (ovector[0] == slen) break;
5151           emptyopt = PCRE_NOTEMPTY | PCRE_ANCHORED;
5152           }
5153         }
5154
5155       /* All done - restore numerical variables. */
5156
5157       restore_expand_strings(save_expand_nmax, save_expand_nstring,
5158         save_expand_nlength);
5159       continue;
5160       }
5161
5162     /* Handle keyed and numbered substring extraction. If the first argument
5163     consists entirely of digits, then a numerical extraction is assumed. */
5164
5165     case EITEM_EXTRACT:
5166       {
5167       int i;
5168       int j = 2;
5169       int field_number = 1;
5170       BOOL field_number_set = FALSE;
5171       uschar *save_lookup_value = lookup_value;
5172       uschar *sub[3];
5173       int save_expand_nmax =
5174         save_expand_strings(save_expand_nstring, save_expand_nlength);
5175
5176       /* Read the arguments */
5177
5178       for (i = 0; i < j; i++)
5179         {
5180         while (isspace(*s)) s++;
5181         if (*s == '{')                                          /*}*/
5182           {
5183           sub[i] = expand_string_internal(s+1, TRUE, &s, skipping, TRUE, &resetok);
5184           if (sub[i] == NULL) goto EXPAND_FAILED;               /*{*/
5185           if (*s++ != '}') goto EXPAND_FAILED_CURLY;
5186
5187           /* After removal of leading and trailing white space, the first
5188           argument must not be empty; if it consists entirely of digits
5189           (optionally preceded by a minus sign), this is a numerical
5190           extraction, and we expect 3 arguments. */
5191
5192           if (i == 0)
5193             {
5194             int len;
5195             int x = 0;
5196             uschar *p = sub[0];
5197
5198             while (isspace(*p)) p++;
5199             sub[0] = p;
5200
5201             len = Ustrlen(p);
5202             while (len > 0 && isspace(p[len-1])) len--;
5203             p[len] = 0;
5204
5205             if (*p == 0 && !skipping)
5206               {
5207               expand_string_message = US"first argument of \"extract\" must "
5208                 "not be empty";
5209               goto EXPAND_FAILED;
5210               }
5211
5212             if (*p == '-')
5213               {
5214               field_number = -1;
5215               p++;
5216               }
5217             while (*p != 0 && isdigit(*p)) x = x * 10 + *p++ - '0';
5218             if (*p == 0)
5219               {
5220               field_number *= x;
5221               j = 3;               /* Need 3 args */
5222               field_number_set = TRUE;
5223               }
5224             }
5225           }
5226         else goto EXPAND_FAILED_CURLY;
5227         }
5228
5229       /* Extract either the numbered or the keyed substring into $value. If
5230       skipping, just pretend the extraction failed. */
5231
5232       lookup_value = skipping? NULL : field_number_set?
5233         expand_gettokened(field_number, sub[1], sub[2]) :
5234         expand_getkeyed(sub[0], sub[1]);
5235
5236       /* If no string follows, $value gets substituted; otherwise there can
5237       be yes/no strings, as for lookup or if. */
5238
5239       switch(process_yesno(
5240                skipping,                     /* were previously skipping */
5241                lookup_value != NULL,         /* success/failure indicator */
5242                save_lookup_value,            /* value to reset for string2 */
5243                &s,                           /* input pointer */
5244                &yield,                       /* output pointer */
5245                &size,                        /* output size */
5246                &ptr,                         /* output current point */
5247                US"extract",                  /* condition type */
5248                &resetok))
5249         {
5250         case 1: goto EXPAND_FAILED;          /* when all is well, the */
5251         case 2: goto EXPAND_FAILED_CURLY;    /* returned value is 0 */
5252         }
5253
5254       /* All done - restore numerical variables. */
5255
5256       restore_expand_strings(save_expand_nmax, save_expand_nstring,
5257         save_expand_nlength);
5258
5259       continue;
5260       }
5261
5262     /* return the Nth item from a list */
5263
5264     case EITEM_LISTEXTRACT:
5265       {
5266       int i;
5267       int field_number = 1;
5268       uschar *save_lookup_value = lookup_value;
5269       uschar *sub[2];
5270       int save_expand_nmax =
5271         save_expand_strings(save_expand_nstring, save_expand_nlength);
5272
5273       /* Read the field & list arguments */
5274
5275       for (i = 0; i < 2; i++)
5276         {
5277         while (isspace(*s)) s++;
5278         if (*s != '{')                                  /*}*/
5279           goto EXPAND_FAILED_CURLY;
5280
5281         sub[i] = expand_string_internal(s+1, TRUE, &s, skipping, TRUE, &resetok);
5282         if (!sub[i])     goto EXPAND_FAILED;            /*{*/
5283         if (*s++ != '}') goto EXPAND_FAILED_CURLY;
5284
5285         /* After removal of leading and trailing white space, the first
5286         argument must be numeric and nonempty. */
5287
5288         if (i == 0)
5289           {
5290           int len;
5291           int x = 0;
5292           uschar *p = sub[0];
5293
5294           while (isspace(*p)) p++;
5295           sub[0] = p;
5296
5297           len = Ustrlen(p);
5298           while (len > 0 && isspace(p[len-1])) len--;
5299           p[len] = 0;
5300
5301           if (!*p && !skipping)
5302             {
5303             expand_string_message = US"first argument of \"listextract\" must "
5304               "not be empty";
5305             goto EXPAND_FAILED;
5306             }
5307
5308           if (*p == '-')
5309             {
5310             field_number = -1;
5311             p++;
5312             }
5313           while (*p && isdigit(*p)) x = x * 10 + *p++ - '0';
5314           if (*p)
5315             {
5316             expand_string_message = US"first argument of \"listextract\" must "
5317               "be numeric";
5318             goto EXPAND_FAILED;
5319             }
5320           field_number *= x;
5321           }
5322         }
5323
5324       /* Extract the numbered element into $value. If
5325       skipping, just pretend the extraction failed. */
5326
5327       lookup_value = skipping? NULL : expand_getlistele(field_number, sub[1]);
5328
5329       /* If no string follows, $value gets substituted; otherwise there can
5330       be yes/no strings, as for lookup or if. */
5331
5332       switch(process_yesno(
5333                skipping,                     /* were previously skipping */
5334                lookup_value != NULL,         /* success/failure indicator */
5335                save_lookup_value,            /* value to reset for string2 */
5336                &s,                           /* input pointer */
5337                &yield,                       /* output pointer */
5338                &size,                        /* output size */
5339                &ptr,                         /* output current point */
5340                US"extract",                  /* condition type */
5341                &resetok))
5342         {
5343         case 1: goto EXPAND_FAILED;          /* when all is well, the */
5344         case 2: goto EXPAND_FAILED_CURLY;    /* returned value is 0 */
5345         }
5346
5347       /* All done - restore numerical variables. */
5348
5349       restore_expand_strings(save_expand_nmax, save_expand_nstring,
5350         save_expand_nlength);
5351
5352       continue;
5353       }
5354
5355 #ifdef SUPPORT_TLS
5356     case EITEM_CERTEXTRACT:
5357       {
5358       int i;
5359       int field_number = 1;
5360       uschar *save_lookup_value = lookup_value;
5361       uschar *sub[2];
5362       int save_expand_nmax =
5363         save_expand_strings(save_expand_nstring, save_expand_nlength);
5364
5365       /* Read the field argument */
5366       while (isspace(*s)) s++;
5367       if (*s != '{')                                    /*}*/
5368         goto EXPAND_FAILED_CURLY;
5369       sub[0] = expand_string_internal(s+1, TRUE, &s, skipping, TRUE, &resetok);
5370       if (!sub[0])     goto EXPAND_FAILED;              /*{*/
5371       if (*s++ != '}') goto EXPAND_FAILED_CURLY;
5372       /* strip spaces fore & aft */
5373       {
5374       int len;
5375       int x = 0;
5376       uschar *p = sub[0];
5377
5378       while (isspace(*p)) p++;
5379       sub[0] = p;
5380
5381       len = Ustrlen(p);
5382       while (len > 0 && isspace(p[len-1])) len--;
5383       p[len] = 0;
5384       }
5385
5386       /* inspect the cert argument */
5387       while (isspace(*s)) s++;
5388       if (*s != '{')                                    /*}*/
5389         goto EXPAND_FAILED_CURLY;
5390       if (*++s != '$')
5391         {
5392         expand_string_message = US"second argument of \"certextract\" must "
5393           "be a certificate variable";
5394         goto EXPAND_FAILED;
5395         }
5396       sub[1] = expand_string_internal(s+1, TRUE, &s, skipping, FALSE, &resetok);
5397       if (!sub[1])     goto EXPAND_FAILED;              /*{*/
5398       if (*s++ != '}') goto EXPAND_FAILED_CURLY;
5399
5400       if (skipping)
5401         lookup_value = NULL;
5402       else
5403         {
5404         lookup_value = expand_getcertele(sub[0], sub[1]);
5405         if (*expand_string_message) goto EXPAND_FAILED;
5406         }
5407       switch(process_yesno(
5408                skipping,                     /* were previously skipping */
5409                lookup_value != NULL,         /* success/failure indicator */
5410                save_lookup_value,            /* value to reset for string2 */
5411                &s,                           /* input pointer */
5412                &yield,                       /* output pointer */
5413                &size,                        /* output size */
5414                &ptr,                         /* output current point */
5415                US"extract",                  /* condition type */
5416                &resetok))
5417         {
5418         case 1: goto EXPAND_FAILED;          /* when all is well, the */
5419         case 2: goto EXPAND_FAILED_CURLY;    /* returned value is 0 */
5420         }
5421
5422       restore_expand_strings(save_expand_nmax, save_expand_nstring,
5423         save_expand_nlength);
5424       continue;
5425       }
5426 #endif  /*SUPPORT_TLS*/
5427
5428     /* Handle list operations */
5429
5430     case EITEM_FILTER:
5431     case EITEM_MAP:
5432     case EITEM_REDUCE:
5433       {
5434       int sep = 0;
5435       int save_ptr = ptr;
5436       uschar outsep[2] = { '\0', '\0' };
5437       uschar *list, *expr, *temp;
5438       uschar *save_iterate_item = iterate_item;
5439       uschar *save_lookup_value = lookup_value;
5440
5441       while (isspace(*s)) s++;
5442       if (*s++ != '{') goto EXPAND_FAILED_CURLY;
5443
5444       list = expand_string_internal(s, TRUE, &s, skipping, TRUE, &resetok);
5445       if (list == NULL) goto EXPAND_FAILED;
5446       if (*s++ != '}') goto EXPAND_FAILED_CURLY;
5447
5448       if (item_type == EITEM_REDUCE)
5449         {
5450         while (isspace(*s)) s++;
5451         if (*s++ != '{') goto EXPAND_FAILED_CURLY;
5452         temp = expand_string_internal(s, TRUE, &s, skipping, TRUE, &resetok);
5453         if (temp == NULL) goto EXPAND_FAILED;
5454         lookup_value = temp;
5455         if (*s++ != '}') goto EXPAND_FAILED_CURLY;
5456         }
5457
5458       while (isspace(*s)) s++;
5459       if (*s++ != '{') goto EXPAND_FAILED_CURLY;
5460
5461       expr = s;
5462
5463       /* For EITEM_FILTER, call eval_condition once, with result discarded (as
5464       if scanning a "false" part). This allows us to find the end of the
5465       condition, because if the list is empty, we won't actually evaluate the
5466       condition for real. For EITEM_MAP and EITEM_REDUCE, do the same, using
5467       the normal internal expansion function. */
5468
5469       if (item_type == EITEM_FILTER)
5470         {
5471         temp = eval_condition(expr, &resetok, NULL);
5472         if (temp != NULL) s = temp;
5473         }
5474       else
5475         {
5476         temp = expand_string_internal(s, TRUE, &s, TRUE, TRUE, &resetok);
5477         }
5478
5479       if (temp == NULL)
5480         {
5481         expand_string_message = string_sprintf("%s inside \"%s\" item",
5482           expand_string_message, name);
5483         goto EXPAND_FAILED;
5484         }
5485
5486       while (isspace(*s)) s++;
5487       if (*s++ != '}')
5488         {                                               /*{*/
5489         expand_string_message = string_sprintf("missing } at end of condition "
5490           "or expression inside \"%s\"", name);
5491         goto EXPAND_FAILED;
5492         }
5493
5494       while (isspace(*s)) s++;                          /*{*/
5495       if (*s++ != '}')
5496         {                                               /*{*/
5497         expand_string_message = string_sprintf("missing } at end of \"%s\"",
5498           name);
5499         goto EXPAND_FAILED;
5500         }
5501
5502       /* If we are skipping, we can now just move on to the next item. When
5503       processing for real, we perform the iteration. */
5504
5505       if (skipping) continue;
5506       while ((iterate_item = string_nextinlist(&list, &sep, NULL, 0)) != NULL)
5507         {
5508         *outsep = (uschar)sep;      /* Separator as a string */
5509
5510         DEBUG(D_expand) debug_printf("%s: $item = \"%s\"\n", name, iterate_item);
5511
5512         if (item_type == EITEM_FILTER)
5513           {
5514           BOOL condresult;
5515           if (eval_condition(expr, &resetok, &condresult) == NULL)
5516             {
5517             iterate_item = save_iterate_item;
5518             lookup_value = save_lookup_value;
5519             expand_string_message = string_sprintf("%s inside \"%s\" condition",
5520               expand_string_message, name);
5521             goto EXPAND_FAILED;
5522             }
5523           DEBUG(D_expand) debug_printf("%s: condition is %s\n", name,
5524             condresult? "true":"false");
5525           if (condresult)
5526             temp = iterate_item;    /* TRUE => include this item */
5527           else
5528             continue;               /* FALSE => skip this item */
5529           }
5530
5531         /* EITEM_MAP and EITEM_REDUCE */
5532
5533         else
5534           {
5535           temp = expand_string_internal(expr, TRUE, NULL, skipping, TRUE, &resetok);
5536           if (temp == NULL)
5537             {
5538             iterate_item = save_iterate_item;
5539             expand_string_message = string_sprintf("%s inside \"%s\" item",
5540               expand_string_message, name);
5541             goto EXPAND_FAILED;
5542             }
5543           if (item_type == EITEM_REDUCE)
5544             {
5545             lookup_value = temp;      /* Update the value of $value */
5546             continue;                 /* and continue the iteration */
5547             }
5548           }
5549
5550         /* We reach here for FILTER if the condition is true, always for MAP,
5551         and never for REDUCE. The value in "temp" is to be added to the output
5552         list that is being created, ensuring that any occurrences of the
5553         separator character are doubled. Unless we are dealing with the first
5554         item of the output list, add in a space if the new item begins with the
5555         separator character, or is an empty string. */
5556
5557         if (ptr != save_ptr && (temp[0] == *outsep || temp[0] == 0))
5558           yield = string_cat(yield, &size, &ptr, US" ", 1);
5559
5560         /* Add the string in "temp" to the output list that we are building,
5561         This is done in chunks by searching for the separator character. */
5562
5563         for (;;)
5564           {
5565           size_t seglen = Ustrcspn(temp, outsep);
5566             yield = string_cat(yield, &size, &ptr, temp, seglen + 1);
5567
5568           /* If we got to the end of the string we output one character
5569           too many; backup and end the loop. Otherwise arrange to double the
5570           separator. */
5571
5572           if (temp[seglen] == '\0') { ptr--; break; }
5573           yield = string_cat(yield, &size, &ptr, outsep, 1);
5574           temp += seglen + 1;
5575           }
5576
5577         /* Output a separator after the string: we will remove the redundant
5578         final one at the end. */
5579
5580         yield = string_cat(yield, &size, &ptr, outsep, 1);
5581         }   /* End of iteration over the list loop */
5582
5583       /* REDUCE has generated no output above: output the final value of
5584       $value. */
5585
5586       if (item_type == EITEM_REDUCE)
5587         {
5588         yield = string_cat(yield, &size, &ptr, lookup_value,
5589           Ustrlen(lookup_value));
5590         lookup_value = save_lookup_value;  /* Restore $value */
5591         }
5592
5593       /* FILTER and MAP generate lists: if they have generated anything, remove
5594       the redundant final separator. Even though an empty item at the end of a
5595       list does not count, this is tidier. */
5596
5597       else if (ptr != save_ptr) ptr--;
5598
5599       /* Restore preserved $item */
5600
5601       iterate_item = save_iterate_item;
5602       continue;
5603       }
5604
5605
5606     /* If ${dlfunc } support is configured, handle calling dynamically-loaded
5607     functions, unless locked out at this time. Syntax is ${dlfunc{file}{func}}
5608     or ${dlfunc{file}{func}{arg}} or ${dlfunc{file}{func}{arg1}{arg2}} or up to
5609     a maximum of EXPAND_DLFUNC_MAX_ARGS arguments (defined below). */
5610
5611     #define EXPAND_DLFUNC_MAX_ARGS 8
5612
5613     case EITEM_DLFUNC:
5614     #ifndef EXPAND_DLFUNC
5615     expand_string_message = US"\"${dlfunc\" encountered, but this facility "    /*}*/
5616       "is not included in this binary";
5617     goto EXPAND_FAILED;
5618
5619     #else   /* EXPAND_DLFUNC */
5620       {
5621       tree_node *t;
5622       exim_dlfunc_t *func;
5623       uschar *result;
5624       int status, argc;
5625       uschar *argv[EXPAND_DLFUNC_MAX_ARGS + 3];
5626
5627       if ((expand_forbid & RDO_DLFUNC) != 0)
5628         {
5629         expand_string_message =
5630           US"dynamically-loaded functions are not permitted";
5631         goto EXPAND_FAILED;
5632         }
5633
5634       switch(read_subs(argv, EXPAND_DLFUNC_MAX_ARGS + 2, 2, &s, skipping,
5635            TRUE, US"dlfunc", &resetok))
5636         {
5637         case 1: goto EXPAND_FAILED_CURLY;
5638         case 2:
5639         case 3: goto EXPAND_FAILED;
5640         }
5641
5642       /* If skipping, we don't actually do anything */
5643
5644       if (skipping) continue;
5645
5646       /* Look up the dynamically loaded object handle in the tree. If it isn't
5647       found, dlopen() the file and put the handle in the tree for next time. */
5648
5649       t = tree_search(dlobj_anchor, argv[0]);
5650       if (t == NULL)
5651         {
5652         void *handle = dlopen(CS argv[0], RTLD_LAZY);
5653         if (handle == NULL)
5654           {
5655           expand_string_message = string_sprintf("dlopen \"%s\" failed: %s",
5656             argv[0], dlerror());
5657           log_write(0, LOG_MAIN|LOG_PANIC, "%s", expand_string_message);
5658           goto EXPAND_FAILED;
5659           }
5660         t = store_get_perm(sizeof(tree_node) + Ustrlen(argv[0]));
5661         Ustrcpy(t->name, argv[0]);
5662         t->data.ptr = handle;
5663         (void)tree_insertnode(&dlobj_anchor, t);
5664         }
5665
5666       /* Having obtained the dynamically loaded object handle, look up the
5667       function pointer. */
5668
5669       func = (exim_dlfunc_t *)dlsym(t->data.ptr, CS argv[1]);
5670       if (func == NULL)
5671         {
5672         expand_string_message = string_sprintf("dlsym \"%s\" in \"%s\" failed: "
5673           "%s", argv[1], argv[0], dlerror());
5674         log_write(0, LOG_MAIN|LOG_PANIC, "%s", expand_string_message);
5675         goto EXPAND_FAILED;
5676         }
5677
5678       /* Call the function and work out what to do with the result. If it
5679       returns OK, we have a replacement string; if it returns DEFER then
5680       expansion has failed in a non-forced manner; if it returns FAIL then
5681       failure was forced; if it returns ERROR or any other value there's a
5682       problem, so panic slightly. In any case, assume that the function has
5683       side-effects on the store that must be preserved. */
5684
5685       resetok = FALSE;
5686       result = NULL;
5687       for (argc = 0; argv[argc] != NULL; argc++);
5688       status = func(&result, argc - 2, &argv[2]);
5689       if(status == OK)
5690         {
5691         if (result == NULL) result = US"";
5692         yield = string_cat(yield, &size, &ptr, result, Ustrlen(result));
5693         continue;
5694         }
5695       else
5696         {
5697         expand_string_message = result == NULL ? US"(no message)" : result;
5698         if(status == FAIL_FORCED) expand_string_forcedfail = TRUE;
5699           else if(status != FAIL)
5700             log_write(0, LOG_MAIN|LOG_PANIC, "dlfunc{%s}{%s} failed (%d): %s",
5701               argv[0], argv[1], status, expand_string_message);
5702         goto EXPAND_FAILED;
5703         }
5704       }
5705     #endif /* EXPAND_DLFUNC */
5706     }   /* EITEM_* switch */
5707
5708   /* Control reaches here if the name is not recognized as one of the more
5709   complicated expansion items. Check for the "operator" syntax (name terminated
5710   by a colon). Some of the operators have arguments, separated by _ from the
5711   name. */
5712
5713   if (*s == ':')
5714     {
5715     int c;
5716     uschar *arg = NULL;
5717     uschar *sub = expand_string_internal(s+1, TRUE, &s, skipping, TRUE, &resetok);
5718     if (sub == NULL) goto EXPAND_FAILED;
5719     s++;
5720
5721     /* Owing to an historical mis-design, an underscore may be part of the
5722     operator name, or it may introduce arguments.  We therefore first scan the
5723     table of names that contain underscores. If there is no match, we cut off
5724     the arguments and then scan the main table. */
5725
5726     c = chop_match(name, op_table_underscore,
5727       sizeof(op_table_underscore)/sizeof(uschar *));
5728
5729     if (c < 0)
5730       {
5731       arg = Ustrchr(name, '_');
5732       if (arg != NULL) *arg = 0;
5733       c = chop_match(name, op_table_main,
5734         sizeof(op_table_main)/sizeof(uschar *));
5735       if (c >= 0) c += sizeof(op_table_underscore)/sizeof(uschar *);
5736       if (arg != NULL) *arg++ = '_';   /* Put back for error messages */
5737       }
5738
5739     /* If we are skipping, we don't need to perform the operation at all.
5740     This matters for operations like "mask", because the data may not be
5741     in the correct format when skipping. For example, the expression may test
5742     for the existence of $sender_host_address before trying to mask it. For
5743     other operations, doing them may not fail, but it is a waste of time. */
5744
5745     if (skipping && c >= 0) continue;
5746
5747     /* Otherwise, switch on the operator type */
5748
5749     switch(c)
5750       {
5751       case EOP_BASE62:
5752         {
5753         uschar *t;
5754         unsigned long int n = Ustrtoul(sub, &t, 10);
5755         if (*t != 0)
5756           {
5757           expand_string_message = string_sprintf("argument for base62 "
5758             "operator is \"%s\", which is not a decimal number", sub);
5759           goto EXPAND_FAILED;
5760           }
5761         t = string_base62(n);
5762         yield = string_cat(yield, &size, &ptr, t, Ustrlen(t));
5763         continue;
5764         }
5765
5766       /* Note that for Darwin and Cygwin, BASE_62 actually has the value 36 */
5767
5768       case EOP_BASE62D:
5769         {
5770         uschar buf[16];
5771         uschar *tt = sub;
5772         unsigned long int n = 0;
5773         while (*tt != 0)
5774           {
5775           uschar *t = Ustrchr(base62_chars, *tt++);
5776           if (t == NULL)
5777             {
5778             expand_string_message = string_sprintf("argument for base62d "
5779               "operator is \"%s\", which is not a base %d number", sub,
5780               BASE_62);
5781             goto EXPAND_FAILED;
5782             }
5783           n = n * BASE_62 + (t - base62_chars);
5784           }
5785         (void)sprintf(CS buf, "%ld", n);
5786         yield = string_cat(yield, &size, &ptr, buf, Ustrlen(buf));
5787         continue;
5788         }
5789
5790       case EOP_EXPAND:
5791         {
5792         uschar *expanded = expand_string_internal(sub, FALSE, NULL, skipping, TRUE, &resetok);
5793         if (expanded == NULL)
5794           {
5795           expand_string_message =
5796             string_sprintf("internal expansion of \"%s\" failed: %s", sub,
5797               expand_string_message);
5798           goto EXPAND_FAILED;
5799           }
5800         yield = string_cat(yield, &size, &ptr, expanded, Ustrlen(expanded));
5801         continue;
5802         }
5803
5804       case EOP_LC:
5805         {
5806         int count = 0;
5807         uschar *t = sub - 1;
5808         while (*(++t) != 0) { *t = tolower(*t); count++; }
5809         yield = string_cat(yield, &size, &ptr, sub, count);
5810         continue;
5811         }
5812
5813       case EOP_UC:
5814         {
5815         int count = 0;
5816         uschar *t = sub - 1;
5817         while (*(++t) != 0) { *t = toupper(*t); count++; }
5818         yield = string_cat(yield, &size, &ptr, sub, count);
5819         continue;
5820         }
5821
5822       case EOP_MD5:
5823         {
5824         md5 base;
5825         uschar digest[16];
5826         int j;
5827         char st[33];
5828         md5_start(&base);
5829         md5_end(&base, sub, Ustrlen(sub), digest);
5830         for(j = 0; j < 16; j++) sprintf(st+2*j, "%02x", digest[j]);
5831         yield = string_cat(yield, &size, &ptr, US st, (int)strlen(st));
5832         continue;
5833         }
5834
5835       case EOP_SHA1:
5836         {
5837         sha1 base;
5838         uschar digest[20];
5839         int j;
5840         char st[41];
5841         sha1_start(&base);
5842         sha1_end(&base, sub, Ustrlen(sub), digest);
5843         for(j = 0; j < 20; j++) sprintf(st+2*j, "%02X", digest[j]);
5844         yield = string_cat(yield, &size, &ptr, US st, (int)strlen(st));
5845         continue;
5846         }
5847
5848       /* Convert hex encoding to base64 encoding */
5849
5850       case EOP_HEX2B64:
5851         {
5852         int c = 0;
5853         int b = -1;
5854         uschar *in = sub;
5855         uschar *out = sub;
5856         uschar *enc;
5857
5858         for (enc = sub; *enc != 0; enc++)
5859           {
5860           if (!isxdigit(*enc))
5861             {
5862             expand_string_message = string_sprintf("\"%s\" is not a hex "
5863               "string", sub);
5864             goto EXPAND_FAILED;
5865             }
5866           c++;
5867           }
5868
5869         if ((c & 1) != 0)
5870           {
5871           expand_string_message = string_sprintf("\"%s\" contains an odd "
5872             "number of characters", sub);
5873           goto EXPAND_FAILED;
5874           }
5875
5876         while ((c = *in++) != 0)
5877           {
5878           if (isdigit(c)) c -= '0';
5879           else c = toupper(c) - 'A' + 10;
5880           if (b == -1)
5881             {
5882             b = c << 4;
5883             }
5884           else
5885             {
5886             *out++ = b | c;
5887             b = -1;
5888             }
5889           }
5890
5891         enc = auth_b64encode(sub, out - sub);
5892         yield = string_cat(yield, &size, &ptr, enc, Ustrlen(enc));
5893         continue;
5894         }
5895
5896       /* Convert octets outside 0x21..0x7E to \xXX form */
5897
5898       case EOP_HEXQUOTE:
5899         {
5900         uschar *t = sub - 1;
5901         while (*(++t) != 0)
5902           {
5903           if (*t < 0x21 || 0x7E < *t)
5904             yield = string_cat(yield, &size, &ptr,
5905               string_sprintf("\\x%02x", *t), 4);
5906           else
5907             yield = string_cat(yield, &size, &ptr, t, 1);
5908           }
5909         continue;
5910         }
5911
5912       /* count the number of list elements */
5913
5914       case EOP_LISTCOUNT:
5915         {
5916         int cnt = 0;
5917         int sep = 0;
5918         uschar * cp;
5919         uschar buffer[256];
5920
5921         while (string_nextinlist(&sub, &sep, buffer, sizeof(buffer)) != NULL) cnt++;
5922         cp = string_sprintf("%d", cnt);
5923         yield = string_cat(yield, &size, &ptr, cp, Ustrlen(cp));
5924         continue;
5925         }
5926
5927       /* expand a named list given the name */
5928       /* handles nested named lists; requotes as colon-sep list */
5929
5930       case EOP_LISTNAMED:
5931         {
5932         tree_node *t = NULL;
5933         uschar * list;
5934         int sep = 0;
5935         uschar * item;
5936         uschar * suffix = US"";
5937         BOOL needsep = FALSE;
5938         uschar buffer[256];
5939
5940         if (*sub == '+') sub++;
5941         if (arg == NULL)        /* no-argument version */
5942           {
5943           if (!(t = tree_search(addresslist_anchor, sub)) &&
5944               !(t = tree_search(domainlist_anchor,  sub)) &&
5945               !(t = tree_search(hostlist_anchor,    sub)))
5946             t = tree_search(localpartlist_anchor, sub);
5947           }
5948         else switch(*arg)       /* specific list-type version */
5949           {
5950           case 'a': t = tree_search(addresslist_anchor,   sub); suffix = US"_a"; break;
5951           case 'd': t = tree_search(domainlist_anchor,    sub); suffix = US"_d"; break;
5952           case 'h': t = tree_search(hostlist_anchor,      sub); suffix = US"_h"; break;
5953           case 'l': t = tree_search(localpartlist_anchor, sub); suffix = US"_l"; break;
5954           default:
5955             expand_string_message = string_sprintf("bad suffix on \"list\" operator");
5956             goto EXPAND_FAILED;
5957           }
5958
5959         if(!t)
5960           {
5961           expand_string_message = string_sprintf("\"%s\" is not a %snamed list",
5962             sub, !arg?""
5963               : *arg=='a'?"address "
5964               : *arg=='d'?"domain "
5965               : *arg=='h'?"host "
5966               : *arg=='l'?"localpart "
5967               : 0);
5968           goto EXPAND_FAILED;
5969           }
5970
5971         list = ((namedlist_block *)(t->data.ptr))->string;
5972
5973         while ((item = string_nextinlist(&list, &sep, buffer, sizeof(buffer))) != NULL)
5974           {
5975           uschar * buf = US" : ";
5976           if (needsep)
5977             yield = string_cat(yield, &size, &ptr, buf, 3);
5978           else
5979             needsep = TRUE;
5980
5981           if (*item == '+')     /* list item is itself a named list */
5982             {
5983             uschar * sub = string_sprintf("${listnamed%s:%s}", suffix, item);
5984             item = expand_string_internal(sub, FALSE, NULL, FALSE, TRUE, &resetok);
5985             }
5986           else if (sep != ':')  /* item from non-colon-sep list, re-quote for colon list-separator */
5987             {
5988             char * cp;
5989             char tok[3];
5990             tok[0] = sep; tok[1] = ':'; tok[2] = 0;
5991             while ((cp= strpbrk((const char *)item, tok)))
5992               {
5993               yield = string_cat(yield, &size, &ptr, item, cp-(char *)item);
5994               if (*cp++ == ':') /* colon in a non-colon-sep list item, needs doubling */
5995                 {
5996                 yield = string_cat(yield, &size, &ptr, US"::", 2);
5997                 item = (uschar *)cp;
5998                 }
5999               else              /* sep in item; should already be doubled; emit once */
6000                 {
6001                 yield = string_cat(yield, &size, &ptr, (uschar *)tok, 1);
6002                 if (*cp == sep) cp++;
6003                 item = (uschar *)cp;
6004                 }
6005               }
6006             }
6007           yield = string_cat(yield, &size, &ptr, item, Ustrlen(item));
6008           }
6009         continue;
6010         }
6011
6012       /* mask applies a mask to an IP address; for example the result of
6013       ${mask:131.111.10.206/28} is 131.111.10.192/28. */
6014
6015       case EOP_MASK:
6016         {
6017         int count;
6018         uschar *endptr;
6019         int binary[4];
6020         int mask, maskoffset;
6021         int type = string_is_ip_address(sub, &maskoffset);
6022         uschar buffer[64];
6023
6024         if (type == 0)
6025           {
6026           expand_string_message = string_sprintf("\"%s\" is not an IP address",
6027            sub);
6028           goto EXPAND_FAILED;
6029           }
6030
6031         if (maskoffset == 0)
6032           {
6033           expand_string_message = string_sprintf("missing mask value in \"%s\"",
6034             sub);
6035           goto EXPAND_FAILED;
6036           }
6037
6038         mask = Ustrtol(sub + maskoffset + 1, &endptr, 10);
6039
6040         if (*endptr != 0 || mask < 0 || mask > ((type == 4)? 32 : 128))
6041           {
6042           expand_string_message = string_sprintf("mask value too big in \"%s\"",
6043             sub);
6044           goto EXPAND_FAILED;
6045           }
6046
6047         /* Convert the address to binary integer(s) and apply the mask */
6048
6049         sub[maskoffset] = 0;
6050         count = host_aton(sub, binary);
6051         host_mask(count, binary, mask);
6052
6053         /* Convert to masked textual format and add to output. */
6054
6055         yield = string_cat(yield, &size, &ptr, buffer,
6056           host_nmtoa(count, binary, mask, buffer, '.'));
6057         continue;
6058         }
6059
6060       case EOP_ADDRESS:
6061       case EOP_LOCAL_PART:
6062       case EOP_DOMAIN:
6063         {
6064         uschar *error;
6065         int start, end, domain;
6066         uschar *t = parse_extract_address(sub, &error, &start, &end, &domain,
6067           FALSE);
6068         if (t != NULL)
6069           {
6070           if (c != EOP_DOMAIN)
6071             {
6072             if (c == EOP_LOCAL_PART && domain != 0) end = start + domain - 1;
6073             yield = string_cat(yield, &size, &ptr, sub+start, end-start);
6074             }
6075           else if (domain != 0)
6076             {
6077             domain += start;
6078             yield = string_cat(yield, &size, &ptr, sub+domain, end-domain);
6079             }
6080           }
6081         continue;
6082         }
6083
6084       case EOP_ADDRESSES:
6085         {
6086         uschar outsep[2] = { ':', '\0' };
6087         uschar *address, *error;
6088         int save_ptr = ptr;
6089         int start, end, domain;  /* Not really used */
6090
6091         while (isspace(*sub)) sub++;
6092         if (*sub == '>') { *outsep = *++sub; ++sub; }
6093         parse_allow_group = TRUE;
6094
6095         for (;;)
6096           {
6097           uschar *p = parse_find_address_end(sub, FALSE);
6098           uschar saveend = *p;
6099           *p = '\0';
6100           address = parse_extract_address(sub, &error, &start, &end, &domain,
6101             FALSE);
6102           *p = saveend;
6103
6104           /* Add the address to the output list that we are building. This is
6105           done in chunks by searching for the separator character. At the
6106           start, unless we are dealing with the first address of the output
6107           list, add in a space if the new address begins with the separator
6108           character, or is an empty string. */
6109
6110           if (address != NULL)
6111             {
6112             if (ptr != save_ptr && address[0] == *outsep)
6113               yield = string_cat(yield, &size, &ptr, US" ", 1);
6114
6115             for (;;)
6116               {
6117               size_t seglen = Ustrcspn(address, outsep);
6118               yield = string_cat(yield, &size, &ptr, address, seglen + 1);
6119
6120               /* If we got to the end of the string we output one character
6121               too many. */
6122
6123               if (address[seglen] == '\0') { ptr--; break; }
6124               yield = string_cat(yield, &size, &ptr, outsep, 1);
6125               address += seglen + 1;
6126               }
6127
6128             /* Output a separator after the string: we will remove the
6129             redundant final one at the end. */
6130
6131             yield = string_cat(yield, &size, &ptr, outsep, 1);
6132             }
6133
6134           if (saveend == '\0') break;
6135           sub = p + 1;
6136           }
6137
6138         /* If we have generated anything, remove the redundant final
6139         separator. */
6140
6141         if (ptr != save_ptr) ptr--;
6142         parse_allow_group = FALSE;
6143         continue;
6144         }
6145
6146
6147       /* quote puts a string in quotes if it is empty or contains anything
6148       other than alphamerics, underscore, dot, or hyphen.
6149
6150       quote_local_part puts a string in quotes if RFC 2821/2822 requires it to
6151       be quoted in order to be a valid local part.
6152
6153       In both cases, newlines and carriage returns are converted into \n and \r
6154       respectively */
6155
6156       case EOP_QUOTE:
6157       case EOP_QUOTE_LOCAL_PART:
6158       if (arg == NULL)
6159         {
6160         BOOL needs_quote = (*sub == 0);      /* TRUE for empty string */
6161         uschar *t = sub - 1;
6162
6163         if (c == EOP_QUOTE)
6164           {
6165           while (!needs_quote && *(++t) != 0)
6166             needs_quote = !isalnum(*t) && !strchr("_-.", *t);
6167           }
6168         else  /* EOP_QUOTE_LOCAL_PART */
6169           {
6170           while (!needs_quote && *(++t) != 0)
6171             needs_quote = !isalnum(*t) &&
6172               strchr("!#$%&'*+-/=?^_`{|}~", *t) == NULL &&
6173               (*t != '.' || t == sub || t[1] == 0);
6174           }
6175
6176         if (needs_quote)
6177           {
6178           yield = string_cat(yield, &size, &ptr, US"\"", 1);
6179           t = sub - 1;
6180           while (*(++t) != 0)
6181             {
6182             if (*t == '\n')
6183               yield = string_cat(yield, &size, &ptr, US"\\n", 2);
6184             else if (*t == '\r')
6185               yield = string_cat(yield, &size, &ptr, US"\\r", 2);
6186             else
6187               {
6188               if (*t == '\\' || *t == '"')
6189                 yield = string_cat(yield, &size, &ptr, US"\\", 1);
6190               yield = string_cat(yield, &size, &ptr, t, 1);
6191               }
6192             }
6193           yield = string_cat(yield, &size, &ptr, US"\"", 1);
6194           }
6195         else yield = string_cat(yield, &size, &ptr, sub, Ustrlen(sub));
6196         continue;
6197         }
6198
6199       /* quote_lookuptype does lookup-specific quoting */
6200
6201       else
6202         {
6203         int n;
6204         uschar *opt = Ustrchr(arg, '_');
6205
6206         if (opt != NULL) *opt++ = 0;
6207
6208         n = search_findtype(arg, Ustrlen(arg));
6209         if (n < 0)
6210           {
6211           expand_string_message = search_error_message;
6212           goto EXPAND_FAILED;
6213           }
6214
6215         if (lookup_list[n]->quote != NULL)
6216           sub = (lookup_list[n]->quote)(sub, opt);
6217         else if (opt != NULL) sub = NULL;
6218
6219         if (sub == NULL)
6220           {
6221           expand_string_message = string_sprintf(
6222             "\"%s\" unrecognized after \"${quote_%s\"",
6223             opt, arg);
6224           goto EXPAND_FAILED;
6225           }
6226
6227         yield = string_cat(yield, &size, &ptr, sub, Ustrlen(sub));
6228         continue;
6229         }
6230
6231       /* rx quote sticks in \ before any non-alphameric character so that
6232       the insertion works in a regular expression. */
6233
6234       case EOP_RXQUOTE:
6235         {
6236         uschar *t = sub - 1;
6237         while (*(++t) != 0)
6238           {
6239           if (!isalnum(*t))
6240             yield = string_cat(yield, &size, &ptr, US"\\", 1);
6241           yield = string_cat(yield, &size, &ptr, t, 1);
6242           }
6243         continue;
6244         }
6245
6246       /* RFC 2047 encodes, assuming headers_charset (default ISO 8859-1) as
6247       prescribed by the RFC, if there are characters that need to be encoded */
6248
6249       case EOP_RFC2047:
6250         {
6251         uschar buffer[2048];
6252         uschar *string = parse_quote_2047(sub, Ustrlen(sub), headers_charset,
6253           buffer, sizeof(buffer), FALSE);
6254         yield = string_cat(yield, &size, &ptr, string, Ustrlen(string));
6255         continue;
6256         }
6257
6258       /* RFC 2047 decode */
6259
6260       case EOP_RFC2047D:
6261         {
6262         int len;
6263         uschar *error;
6264         uschar *decoded = rfc2047_decode(sub, check_rfc2047_length,
6265           headers_charset, '?', &len, &error);
6266         if (error != NULL)
6267           {
6268           expand_string_message = error;
6269           goto EXPAND_FAILED;
6270           }
6271         yield = string_cat(yield, &size, &ptr, decoded, len);
6272         continue;
6273         }
6274
6275       /* from_utf8 converts UTF-8 to 8859-1, turning non-existent chars into
6276       underscores */
6277
6278       case EOP_FROM_UTF8:
6279         {
6280         while (*sub != 0)
6281           {
6282           int c;
6283           uschar buff[4];
6284           GETUTF8INC(c, sub);
6285           if (c > 255) c = '_';
6286           buff[0] = c;
6287           yield = string_cat(yield, &size, &ptr, buff, 1);
6288           }
6289         continue;
6290         }
6291
6292           /* replace illegal UTF-8 sequences by replacement character  */
6293
6294       #define UTF8_REPLACEMENT_CHAR US"?"
6295
6296       case EOP_UTF8CLEAN:
6297         {
6298         int seq_len, index = 0;
6299         int bytes_left  = 0;
6300         uschar seq_buff[4];                     /* accumulate utf-8 here */
6301
6302         while (*sub != 0)
6303           {
6304           int complete;
6305           long codepoint;
6306           uschar c;
6307
6308           complete = 0;
6309           c = *sub++;
6310           if(bytes_left)
6311             {
6312             if ((c & 0xc0) != 0x80)
6313               {
6314                     /* wrong continuation byte; invalidate all bytes */
6315               complete = 1; /* error */
6316               }
6317             else
6318               {
6319               codepoint = (codepoint << 6) | (c & 0x3f);
6320               seq_buff[index++] = c;
6321               if (--bytes_left == 0)            /* codepoint complete */
6322                 {
6323                 if(codepoint > 0x10FFFF)        /* is it too large? */
6324                   complete = -1;        /* error */
6325                 else
6326                   {             /* finished; output utf-8 sequence */
6327                   yield = string_cat(yield, &size, &ptr, seq_buff, seq_len);
6328                   index = 0;
6329                   }
6330                 }
6331               }
6332             }
6333           else  /* no bytes left: new sequence */
6334             {
6335             if((c & 0x80) == 0) /* 1-byte sequence, US-ASCII, keep it */
6336               {
6337               yield = string_cat(yield, &size, &ptr, &c, 1);
6338               continue;
6339               }
6340             if((c & 0xe0) == 0xc0)              /* 2-byte sequence */
6341               {
6342               if(c == 0xc0 || c == 0xc1)        /* 0xc0 and 0xc1 are illegal */
6343                 complete = -1;
6344               else
6345                 {
6346                   bytes_left = 1;
6347                   codepoint = c & 0x1f;
6348                 }
6349               }
6350             else if((c & 0xf0) == 0xe0)         /* 3-byte sequence */
6351               {
6352               bytes_left = 2;
6353               codepoint = c & 0x0f;
6354               }
6355             else if((c & 0xf8) == 0xf0)         /* 4-byte sequence */
6356               {
6357               bytes_left = 3;
6358               codepoint = c & 0x07;
6359               }
6360             else        /* invalid or too long (RFC3629 allows only 4 bytes) */
6361               complete = -1;
6362
6363             seq_buff[index++] = c;
6364             seq_len = bytes_left + 1;
6365             }           /* if(bytes_left) */
6366
6367           if (complete != 0)
6368             {
6369             bytes_left = index = 0;
6370             yield = string_cat(yield, &size, &ptr, UTF8_REPLACEMENT_CHAR, 1);
6371             }
6372           if ((complete == 1) && ((c & 0x80) == 0))
6373             { /* ASCII character follows incomplete sequence */
6374               yield = string_cat(yield, &size, &ptr, &c, 1);
6375             }
6376           }
6377         continue;
6378         }
6379
6380       /* escape turns all non-printing characters into escape sequences. */
6381
6382       case EOP_ESCAPE:
6383         {
6384         uschar *t = string_printing(sub);
6385         yield = string_cat(yield, &size, &ptr, t, Ustrlen(t));
6386         continue;
6387         }
6388
6389       /* Handle numeric expression evaluation */
6390
6391       case EOP_EVAL:
6392       case EOP_EVAL10:
6393         {
6394         uschar *save_sub = sub;
6395         uschar *error = NULL;
6396         int_eximarith_t n = eval_expr(&sub, (c == EOP_EVAL10), &error, FALSE);
6397         if (error != NULL)
6398           {
6399           expand_string_message = string_sprintf("error in expression "
6400             "evaluation: %s (after processing \"%.*s\")", error, sub-save_sub,
6401               save_sub);
6402           goto EXPAND_FAILED;
6403           }
6404         sprintf(CS var_buffer, PR_EXIM_ARITH, n);
6405         yield = string_cat(yield, &size, &ptr, var_buffer, Ustrlen(var_buffer));
6406         continue;
6407         }
6408
6409       /* Handle time period formating */
6410
6411       case EOP_TIME_EVAL:
6412         {
6413         int n = readconf_readtime(sub, 0, FALSE);
6414         if (n < 0)
6415           {
6416           expand_string_message = string_sprintf("string \"%s\" is not an "
6417             "Exim time interval in \"%s\" operator", sub, name);
6418           goto EXPAND_FAILED;
6419           }
6420         sprintf(CS var_buffer, "%d", n);
6421         yield = string_cat(yield, &size, &ptr, var_buffer, Ustrlen(var_buffer));
6422         continue;
6423         }
6424
6425       case EOP_TIME_INTERVAL:
6426         {
6427         int n;
6428         uschar *t = read_number(&n, sub);
6429         if (*t != 0) /* Not A Number*/
6430           {
6431           expand_string_message = string_sprintf("string \"%s\" is not a "
6432             "positive number in \"%s\" operator", sub, name);
6433           goto EXPAND_FAILED;
6434           }
6435         t = readconf_printtime(n);
6436         yield = string_cat(yield, &size, &ptr, t, Ustrlen(t));
6437         continue;
6438         }
6439
6440       /* Convert string to base64 encoding */
6441
6442       case EOP_STR2B64:
6443         {
6444         uschar *encstr = auth_b64encode(sub, Ustrlen(sub));
6445         yield = string_cat(yield, &size, &ptr, encstr, Ustrlen(encstr));
6446         continue;
6447         }
6448
6449       /* strlen returns the length of the string */
6450
6451       case EOP_STRLEN:
6452         {
6453         uschar buff[24];
6454         (void)sprintf(CS buff, "%d", Ustrlen(sub));
6455         yield = string_cat(yield, &size, &ptr, buff, Ustrlen(buff));
6456         continue;
6457         }
6458
6459       /* length_n or l_n takes just the first n characters or the whole string,
6460       whichever is the shorter;
6461
6462       substr_m_n, and s_m_n take n characters from offset m; negative m take
6463       from the end; l_n is synonymous with s_0_n. If n is omitted in substr it
6464       takes the rest, either to the right or to the left.
6465
6466       hash_n or h_n makes a hash of length n from the string, yielding n
6467       characters from the set a-z; hash_n_m makes a hash of length n, but
6468       uses m characters from the set a-zA-Z0-9.
6469
6470       nhash_n returns a single number between 0 and n-1 (in text form), while
6471       nhash_n_m returns a div/mod hash as two numbers "a/b". The first lies
6472       between 0 and n-1 and the second between 0 and m-1. */
6473
6474       case EOP_LENGTH:
6475       case EOP_L:
6476       case EOP_SUBSTR:
6477       case EOP_S:
6478       case EOP_HASH:
6479       case EOP_H:
6480       case EOP_NHASH:
6481       case EOP_NH:
6482         {
6483         int sign = 1;
6484         int value1 = 0;
6485         int value2 = -1;
6486         int *pn;
6487         int len;
6488         uschar *ret;
6489
6490         if (arg == NULL)
6491           {
6492           expand_string_message = string_sprintf("missing values after %s",
6493             name);
6494           goto EXPAND_FAILED;
6495           }
6496
6497         /* "length" has only one argument, effectively being synonymous with
6498         substr_0_n. */
6499
6500         if (c == EOP_LENGTH || c == EOP_L)
6501           {
6502           pn = &value2;
6503           value2 = 0;
6504           }
6505
6506         /* The others have one or two arguments; for "substr" the first may be
6507         negative. The second being negative means "not supplied". */
6508
6509         else
6510           {
6511           pn = &value1;
6512           if (name[0] == 's' && *arg == '-') { sign = -1; arg++; }
6513           }
6514
6515         /* Read up to two numbers, separated by underscores */
6516
6517         ret = arg;
6518         while (*arg != 0)
6519           {
6520           if (arg != ret && *arg == '_' && pn == &value1)
6521             {
6522             pn = &value2;
6523             value2 = 0;
6524             if (arg[1] != 0) arg++;
6525             }
6526           else if (!isdigit(*arg))
6527             {
6528             expand_string_message =
6529               string_sprintf("non-digit after underscore in \"%s\"", name);
6530             goto EXPAND_FAILED;
6531             }
6532           else *pn = (*pn)*10 + *arg++ - '0';
6533           }
6534         value1 *= sign;
6535
6536         /* Perform the required operation */
6537
6538         ret =
6539           (c == EOP_HASH || c == EOP_H)?
6540              compute_hash(sub, value1, value2, &len) :
6541           (c == EOP_NHASH || c == EOP_NH)?
6542              compute_nhash(sub, value1, value2, &len) :
6543              extract_substr(sub, value1, value2, &len);
6544
6545         if (ret == NULL) goto EXPAND_FAILED;
6546         yield = string_cat(yield, &size, &ptr, ret, len);
6547         continue;
6548         }
6549
6550       /* Stat a path */
6551
6552       case EOP_STAT:
6553         {
6554         uschar *s;
6555         uschar smode[12];
6556         uschar **modetable[3];
6557         int i;
6558         mode_t mode;
6559         struct stat st;
6560
6561         if ((expand_forbid & RDO_EXISTS) != 0)
6562           {
6563           expand_string_message = US"Use of the stat() expansion is not permitted";
6564           goto EXPAND_FAILED;
6565           }
6566
6567         if (stat(CS sub, &st) < 0)
6568           {
6569           expand_string_message = string_sprintf("stat(%s) failed: %s",
6570             sub, strerror(errno));
6571           goto EXPAND_FAILED;
6572           }
6573         mode = st.st_mode;
6574         switch (mode & S_IFMT)
6575           {
6576           case S_IFIFO: smode[0] = 'p'; break;
6577           case S_IFCHR: smode[0] = 'c'; break;
6578           case S_IFDIR: smode[0] = 'd'; break;
6579           case S_IFBLK: smode[0] = 'b'; break;
6580           case S_IFREG: smode[0] = '-'; break;
6581           default: smode[0] = '?'; break;
6582           }
6583
6584         modetable[0] = ((mode & 01000) == 0)? mtable_normal : mtable_sticky;
6585         modetable[1] = ((mode & 02000) == 0)? mtable_normal : mtable_setid;
6586         modetable[2] = ((mode & 04000) == 0)? mtable_normal : mtable_setid;
6587
6588         for (i = 0; i < 3; i++)
6589           {
6590           memcpy(CS(smode + 7 - i*3), CS(modetable[i][mode & 7]), 3);
6591           mode >>= 3;
6592           }
6593
6594         smode[10] = 0;
6595         s = string_sprintf("mode=%04lo smode=%s inode=%ld device=%ld links=%ld "
6596           "uid=%ld gid=%ld size=" OFF_T_FMT " atime=%ld mtime=%ld ctime=%ld",
6597           (long)(st.st_mode & 077777), smode, (long)st.st_ino,
6598           (long)st.st_dev, (long)st.st_nlink, (long)st.st_uid,
6599           (long)st.st_gid, st.st_size, (long)st.st_atime,
6600           (long)st.st_mtime, (long)st.st_ctime);
6601         yield = string_cat(yield, &size, &ptr, s, Ustrlen(s));
6602         continue;
6603         }
6604
6605       /* vaguely random number less than N */
6606
6607       case EOP_RANDINT:
6608         {
6609         int_eximarith_t max;
6610         uschar *s;
6611
6612         max = expand_string_integer(sub, TRUE);
6613         if (expand_string_message != NULL)
6614           goto EXPAND_FAILED;
6615         s = string_sprintf("%d", vaguely_random_number((int)max));
6616         yield = string_cat(yield, &size, &ptr, s, Ustrlen(s));
6617         continue;
6618         }
6619
6620       /* Reverse IP, including IPv6 to dotted-nibble */
6621
6622       case EOP_REVERSE_IP:
6623         {
6624         int family, maskptr;
6625         uschar reversed[128];
6626
6627         family = string_is_ip_address(sub, &maskptr);
6628         if (family == 0)
6629           {
6630           expand_string_message = string_sprintf(
6631               "reverse_ip() not given an IP address [%s]", sub);
6632           goto EXPAND_FAILED;
6633           }
6634         invert_address(reversed, sub);
6635         yield = string_cat(yield, &size, &ptr, reversed, Ustrlen(reversed));
6636         continue;
6637         }
6638
6639       /* Unknown operator */
6640
6641       default:
6642       expand_string_message =
6643         string_sprintf("unknown expansion operator \"%s\"", name);
6644       goto EXPAND_FAILED;
6645       }
6646     }
6647
6648   /* Handle a plain name. If this is the first thing in the expansion, release
6649   the pre-allocated buffer. If the result data is known to be in a new buffer,
6650   newsize will be set to the size of that buffer, and we can just point at that
6651   store instead of copying. Many expansion strings contain just one reference,
6652   so this is a useful optimization, especially for humungous headers
6653   ($message_headers). */
6654                                                 /*{*/
6655   if (*s++ == '}')
6656     {
6657     int len;
6658     int newsize = 0;
6659     if (ptr == 0)
6660       {
6661       if (resetok) store_reset(yield);
6662       yield = NULL;
6663       size = 0;
6664       }
6665     value = find_variable(name, FALSE, skipping, &newsize);
6666     if (value == NULL)
6667       {
6668       expand_string_message =
6669         string_sprintf("unknown variable in \"${%s}\"", name);
6670       check_variable_error_message(name);
6671       goto EXPAND_FAILED;
6672       }
6673     len = Ustrlen(value);
6674     if (yield == NULL && newsize != 0)
6675       {
6676       yield = value;
6677       size = newsize;
6678       ptr = len;
6679       }
6680     else yield = string_cat(yield, &size, &ptr, value, len);
6681     continue;
6682     }
6683
6684   /* Else there's something wrong */
6685
6686   expand_string_message =
6687     string_sprintf("\"${%s\" is not a known operator (or a } is missing "
6688     "in a variable reference)", name);
6689   goto EXPAND_FAILED;
6690   }
6691
6692 /* If we hit the end of the string when ket_ends is set, there is a missing
6693 terminating brace. */
6694
6695 if (ket_ends && *s == 0)
6696   {
6697   expand_string_message = malformed_header?
6698     US"missing } at end of string - could be header name not terminated by colon"
6699     :
6700     US"missing } at end of string";
6701   goto EXPAND_FAILED;
6702   }
6703
6704 /* Expansion succeeded; yield may still be NULL here if nothing was actually
6705 added to the string. If so, set up an empty string. Add a terminating zero. If
6706 left != NULL, return a pointer to the terminator. */
6707
6708 if (yield == NULL) yield = store_get(1);
6709 yield[ptr] = 0;
6710 if (left != NULL) *left = s;
6711
6712 /* Any stacking store that was used above the final string is no longer needed.
6713 In many cases the final string will be the first one that was got and so there
6714 will be optimal store usage. */
6715
6716 if (resetok) store_reset(yield + ptr + 1);
6717 else if (resetok_p) *resetok_p = FALSE;
6718
6719 DEBUG(D_expand)
6720   {
6721   debug_printf("expanding: %.*s\n   result: %s\n", (int)(s - string), string,
6722     yield);
6723   if (skipping) debug_printf("skipping: result is not used\n");
6724   }
6725 return yield;
6726
6727 /* This is the failure exit: easiest to program with a goto. We still need
6728 to update the pointer to the terminator, for cases of nested calls with "fail".
6729 */
6730
6731 EXPAND_FAILED_CURLY:
6732 expand_string_message = malformed_header?
6733   US"missing or misplaced { or } - could be header name not terminated by colon"
6734   :
6735   US"missing or misplaced { or }";
6736
6737 /* At one point, Exim reset the store to yield (if yield was not NULL), but
6738 that is a bad idea, because expand_string_message is in dynamic store. */
6739
6740 EXPAND_FAILED:
6741 if (left != NULL) *left = s;
6742 DEBUG(D_expand)
6743   {
6744   debug_printf("failed to expand: %s\n", string);
6745   debug_printf("   error message: %s\n", expand_string_message);
6746   if (expand_string_forcedfail) debug_printf("failure was forced\n");
6747   }
6748 if (resetok_p) *resetok_p = resetok;
6749 return NULL;
6750 }
6751
6752
6753 /* This is the external function call. Do a quick check for any expansion
6754 metacharacters, and if there are none, just return the input string.
6755
6756 Argument: the string to be expanded
6757 Returns:  the expanded string, or NULL if expansion failed; if failure was
6758           due to a lookup deferring, search_find_defer will be TRUE
6759 */
6760
6761 uschar *
6762 expand_string(uschar *string)
6763 {
6764 search_find_defer = FALSE;
6765 malformed_header = FALSE;
6766 return (Ustrpbrk(string, "$\\") == NULL)? string :
6767   expand_string_internal(string, FALSE, NULL, FALSE, TRUE, NULL);
6768 }
6769
6770
6771
6772 /*************************************************
6773 *              Expand and copy                   *
6774 *************************************************/
6775
6776 /* Now and again we want to expand a string and be sure that the result is in a
6777 new bit of store. This function does that.
6778
6779 Argument: the string to be expanded
6780 Returns:  the expanded string, always in a new bit of store, or NULL
6781 */
6782
6783 uschar *
6784 expand_string_copy(uschar *string)
6785 {
6786 uschar *yield = expand_string(string);
6787 if (yield == string) yield = string_copy(string);
6788 return yield;
6789 }
6790
6791
6792
6793 /*************************************************
6794 *        Expand and interpret as an integer      *
6795 *************************************************/
6796
6797 /* Expand a string, and convert the result into an integer.
6798
6799 Arguments:
6800   string  the string to be expanded
6801   isplus  TRUE if a non-negative number is expected
6802
6803 Returns:  the integer value, or
6804           -1 for an expansion error               ) in both cases, message in
6805           -2 for an integer interpretation error  ) expand_string_message
6806           expand_string_message is set NULL for an OK integer
6807 */
6808
6809 int_eximarith_t
6810 expand_string_integer(uschar *string, BOOL isplus)
6811 {
6812 int_eximarith_t value;
6813 uschar *s = expand_string(string);
6814 uschar *msg = US"invalid integer \"%s\"";
6815 uschar *endptr;
6816
6817 /* If expansion failed, expand_string_message will be set. */
6818
6819 if (s == NULL) return -1;
6820
6821 /* On an overflow, strtol() returns LONG_MAX or LONG_MIN, and sets errno
6822 to ERANGE. When there isn't an overflow, errno is not changed, at least on some
6823 systems, so we set it zero ourselves. */
6824
6825 errno = 0;
6826 expand_string_message = NULL;               /* Indicates no error */
6827
6828 /* Before Exim 4.64, strings consisting entirely of whitespace compared
6829 equal to 0.  Unfortunately, people actually relied upon that, so preserve
6830 the behaviour explicitly.  Stripping leading whitespace is a harmless
6831 noop change since strtol skips it anyway (provided that there is a number
6832 to find at all). */
6833 if (isspace(*s))
6834   {
6835   while (isspace(*s)) ++s;
6836   if (*s == '\0')
6837     {
6838       DEBUG(D_expand)
6839        debug_printf("treating blank string as number 0\n");
6840       return 0;
6841     }
6842   }
6843
6844 value = strtoll(CS s, CSS &endptr, 10);
6845
6846 if (endptr == s)
6847   {
6848   msg = US"integer expected but \"%s\" found";
6849   }
6850 else if (value < 0 && isplus)
6851   {
6852   msg = US"non-negative integer expected but \"%s\" found";
6853   }
6854 else
6855   {
6856   switch (tolower(*endptr))
6857     {
6858     default:
6859       break;
6860     case 'k':
6861       if (value > EXIM_ARITH_MAX/1024 || value < EXIM_ARITH_MIN/1024) errno = ERANGE;
6862       else value *= 1024;
6863       endptr++;
6864       break;
6865     case 'm':
6866       if (value > EXIM_ARITH_MAX/(1024*1024) || value < EXIM_ARITH_MIN/(1024*1024)) errno = ERANGE;
6867       else value *= 1024*1024;
6868       endptr++;
6869       break;
6870     case 'g':
6871       if (value > EXIM_ARITH_MAX/(1024*1024*1024) || value < EXIM_ARITH_MIN/(1024*1024*1024)) errno = ERANGE;
6872       else value *= 1024*1024*1024;
6873       endptr++;
6874       break;
6875     }
6876   if (errno == ERANGE)
6877     msg = US"absolute value of integer \"%s\" is too large (overflow)";
6878   else
6879     {
6880     while (isspace(*endptr)) endptr++;
6881     if (*endptr == 0) return value;
6882     }
6883   }
6884
6885 expand_string_message = string_sprintf(CS msg, s);
6886 return -2;
6887 }
6888
6889
6890 /*************************************************
6891 **************************************************
6892 *             Stand-alone test program           *
6893 **************************************************
6894 *************************************************/
6895
6896 #ifdef STAND_ALONE
6897
6898
6899 BOOL
6900 regex_match_and_setup(const pcre *re, uschar *subject, int options, int setup)
6901 {
6902 int ovector[3*(EXPAND_MAXN+1)];
6903 int n = pcre_exec(re, NULL, subject, Ustrlen(subject), 0, PCRE_EOPT|options,
6904   ovector, sizeof(ovector)/sizeof(int));
6905 BOOL yield = n >= 0;
6906 if (n == 0) n = EXPAND_MAXN + 1;
6907 if (yield)
6908   {
6909   int nn;
6910   expand_nmax = (setup < 0)? 0 : setup + 1;
6911   for (nn = (setup < 0)? 0 : 2; nn < n*2; nn += 2)
6912     {
6913     expand_nstring[expand_nmax] = subject + ovector[nn];
6914     expand_nlength[expand_nmax++] = ovector[nn+1] - ovector[nn];
6915     }
6916   expand_nmax--;
6917   }
6918 return yield;
6919 }
6920
6921
6922 int main(int argc, uschar **argv)
6923 {
6924 int i;
6925 uschar buffer[1024];
6926
6927 debug_selector = D_v;
6928 debug_file = stderr;
6929 debug_fd = fileno(debug_file);
6930 big_buffer = malloc(big_buffer_size);
6931
6932 for (i = 1; i < argc; i++)
6933   {
6934   if (argv[i][0] == '+')
6935     {
6936     debug_trace_memory = 2;
6937     argv[i]++;
6938     }
6939   if (isdigit(argv[i][0]))
6940     debug_selector = Ustrtol(argv[i], NULL, 0);
6941   else
6942     if (Ustrspn(argv[i], "abcdefghijklmnopqrtsuvwxyz0123456789-.:/") ==
6943         Ustrlen(argv[i]))
6944       {
6945       #ifdef LOOKUP_LDAP
6946       eldap_default_servers = argv[i];
6947       #endif
6948       #ifdef LOOKUP_MYSQL
6949       mysql_servers = argv[i];
6950       #endif
6951       #ifdef LOOKUP_PGSQL
6952       pgsql_servers = argv[i];
6953       #endif
6954       #ifdef EXPERIMENTAL_REDIS
6955       redis_servers = argv[i];
6956       #endif
6957       }
6958   #ifdef EXIM_PERL
6959   else opt_perl_startup = argv[i];
6960   #endif
6961   }
6962
6963 printf("Testing string expansion: debug_level = %d\n\n", debug_level);
6964
6965 expand_nstring[1] = US"string 1....";
6966 expand_nlength[1] = 8;
6967 expand_nmax = 1;
6968
6969 #ifdef EXIM_PERL
6970 if (opt_perl_startup != NULL)
6971   {
6972   uschar *errstr;
6973   printf("Starting Perl interpreter\n");
6974   errstr = init_perl(opt_perl_startup);
6975   if (errstr != NULL)
6976     {
6977     printf("** error in perl_startup code: %s\n", errstr);
6978     return EXIT_FAILURE;
6979     }
6980   }
6981 #endif /* EXIM_PERL */
6982
6983 while (fgets(buffer, sizeof(buffer), stdin) != NULL)
6984   {
6985   void *reset_point = store_get(0);
6986   uschar *yield = expand_string(buffer);
6987   if (yield != NULL)
6988     {
6989     printf("%s\n", yield);
6990     store_reset(reset_point);
6991     }
6992   else
6993     {
6994     if (search_find_defer) printf("search_find deferred\n");
6995     printf("Failed: %s\n", expand_string_message);
6996     if (expand_string_forcedfail) printf("Forced failure\n");
6997     printf("\n");
6998     }
6999   }
7000
7001 search_tidyup();
7002
7003 return 0;
7004 }
7005
7006 #endif
7007
7008 /*
7009  vi: aw ai sw=2
7010 */
7011 /* End of expand.c */