9cf9866a3c8240b80813fbe73a7634128a43a574
[exim.git] / src / src / routers / redirect.c
1 /*************************************************
2 *     Exim - an Internet mail transport agent    *
3 *************************************************/
4
5 /* Copyright (c) University of Cambridge 1995 - 2018 */
6 /* See the file NOTICE for conditions of use and distribution. */
7
8
9 #include "../exim.h"
10 #include "rf_functions.h"
11 #include "redirect.h"
12
13
14
15 /* Options specific to the redirect router. */
16 #define LOFF(field) OPT_OFF(redirect_router_options_block, field)
17
18 optionlist redirect_router_options[] = {
19   { "allow_defer",        opt_bit | (RDON_DEFER << 16),
20       LOFF(bit_options) },
21   { "allow_fail",         opt_bit | (RDON_FAIL << 16),
22       LOFF(bit_options) },
23   { "allow_filter",       opt_bit | (RDON_FILTER << 16),
24       LOFF(bit_options) },
25   { "allow_freeze",       opt_bit | (RDON_FREEZE << 16),
26       LOFF(bit_options) },
27   { "check_ancestor",     opt_bool,             LOFF(check_ancestor) },
28   { "check_group",        opt_bool,             LOFF(check_group) },
29   { "check_owner",        opt_bool,             LOFF(check_owner) },
30   { "data",               opt_stringptr,        LOFF(data) },
31   { "directory_transport",opt_stringptr,        LOFF(directory_transport_name) },
32   { "file",               opt_stringptr,        LOFF(file) },
33   { "file_transport",     opt_stringptr,        LOFF(file_transport_name) },
34
35   { "filter_prepend_home",opt_bit | (RDON_PREPEND_HOME << 16),
36       LOFF(bit_options) },
37   { "forbid_blackhole",   opt_bit | (RDON_BLACKHOLE << 16),
38       LOFF(bit_options) },
39   { "forbid_exim_filter", opt_bit | (RDON_EXIM_FILTER << 16),
40       LOFF(bit_options) },
41   { "forbid_file",        opt_bool,
42       LOFF(forbid_file) },
43   { "forbid_filter_dlfunc", opt_bit | (RDON_DLFUNC << 16),
44       LOFF(bit_options) },
45   { "forbid_filter_existstest",  opt_bit | (RDON_EXISTS << 16),
46       LOFF(bit_options) },
47   { "forbid_filter_logwrite",opt_bit | (RDON_LOG << 16),
48       LOFF(bit_options) },
49   { "forbid_filter_lookup", opt_bit | (RDON_LOOKUP << 16),
50       LOFF(bit_options) },
51   { "forbid_filter_perl", opt_bit | (RDON_PERL << 16),
52       LOFF(bit_options) },
53   { "forbid_filter_readfile", opt_bit | (RDON_READFILE << 16),
54       LOFF(bit_options) },
55   { "forbid_filter_readsocket", opt_bit | (RDON_READSOCK << 16),
56       LOFF(bit_options) },
57   { "forbid_filter_reply",opt_bool,
58       LOFF(forbid_filter_reply) },
59   { "forbid_filter_run",  opt_bit | (RDON_RUN << 16),
60       LOFF(bit_options) },
61   { "forbid_include",     opt_bit | (RDON_INCLUDE << 16),
62       LOFF(bit_options) },
63   { "forbid_pipe",        opt_bool,
64       LOFF(forbid_pipe) },
65   { "forbid_sieve_filter",opt_bit | (RDON_SIEVE_FILTER << 16),
66       LOFF(bit_options) },
67   { "forbid_smtp_code",     opt_bool,
68       LOFF(forbid_smtp_code) },
69   { "hide_child_in_errmsg", opt_bool,
70       LOFF( hide_child_in_errmsg) },
71   { "ignore_eacces",      opt_bit | (RDON_EACCES << 16),
72       LOFF(bit_options) },
73   { "ignore_enotdir",     opt_bit | (RDON_ENOTDIR << 16),
74       LOFF(bit_options) },
75
76   { "include_directory",  opt_stringptr,        LOFF( include_directory) },
77   { "modemask",           opt_octint,           LOFF(modemask) },
78   { "one_time",           opt_bool,             LOFF(one_time) },
79   { "owners",             opt_uidlist,          LOFF(owners) },
80   { "owngroups",          opt_gidlist,          LOFF(owngroups) },
81   { "pipe_transport",     opt_stringptr,        LOFF(pipe_transport_name) },
82   { "qualify_domain",     opt_stringptr,        LOFF(qualify_domain) },
83   { "qualify_preserve_domain", opt_bool,        LOFF(qualify_preserve_domain) },
84   { "repeat_use",         opt_bool | opt_public, OPT_OFF(router_instance, repeat_use) },
85   { "reply_transport",    opt_stringptr,        LOFF(reply_transport_name) },
86
87   { "rewrite",            opt_bit | (RDON_REWRITE << 16),
88       LOFF(bit_options) },
89
90   { "sieve_enotify_mailto_owner", opt_stringptr, LOFF(sieve_enotify_mailto_owner) },
91   { "sieve_subaddress", opt_stringptr,          LOFF(sieve_subaddress) },
92   { "sieve_useraddress", opt_stringptr,         LOFF(sieve_useraddress) },
93   { "sieve_vacation_directory", opt_stringptr,  LOFF(sieve_vacation_directory) },
94   { "skip_syntax_errors", opt_bool,             LOFF(skip_syntax_errors) },
95 #ifdef EXPERIMENTAL_SRS
96   { "srs",                opt_stringptr,        LOFF(srs) },
97   { "srs_alias",          opt_stringptr,        LOFF(srs_alias) },
98   { "srs_condition",      opt_stringptr,        LOFF(srs_condition) },
99   { "srs_dbinsert",       opt_stringptr,        LOFF(srs_dbinsert) },
100   { "srs_dbselect",       opt_stringptr,        LOFF(srs_dbselect) },
101 #endif
102   { "syntax_errors_text", opt_stringptr,        LOFF(syntax_errors_text) },
103   { "syntax_errors_to",   opt_stringptr,        LOFF(syntax_errors_to) }
104 };
105
106 /* Size of the options list. An extern variable has to be used so that its
107 address can appear in the tables drtables.c. */
108
109 int redirect_router_options_count =
110   sizeof(redirect_router_options)/sizeof(optionlist);
111
112
113 #ifdef MACRO_PREDEF
114
115 /* Dummy entries */
116 redirect_router_options_block redirect_router_option_defaults = {0};
117 void redirect_router_init(router_instance *rblock) {}
118 int redirect_router_entry(router_instance *rblock, address_item *addr,
119   struct passwd *pw, int verify, address_item **addr_local,
120   address_item **addr_remote, address_item **addr_new,
121   address_item **addr_succeed) {return 0;}
122
123 #else   /*!MACRO_PREDEF*/
124
125
126
127 /* Default private options block for the redirect router. */
128
129 redirect_router_options_block redirect_router_option_defaults = {
130   NULL,        /* directory_transport */
131   NULL,        /* file_transport */
132   NULL,        /* pipe_transport */
133   NULL,        /* reply_transport */
134   NULL,        /* data */
135   NULL,        /* directory_transport_name */
136   NULL,        /* file */
137   NULL,        /* file_dir */
138   NULL,        /* file_transport_name */
139   NULL,        /* include_directory */
140   NULL,        /* pipe_transport_name */
141   NULL,        /* reply_transport_name */
142   NULL,        /* sieve_subaddress */
143   NULL,        /* sieve_useraddress */
144   NULL,        /* sieve_vacation_directory */
145   NULL,        /* sieve_enotify_mailto_owner */
146   NULL,        /* syntax_errors_text */
147   NULL,        /* syntax_errors_to */
148   NULL,        /* qualify_domain */
149   NULL,        /* owners */
150   NULL,        /* owngroups */
151 #ifdef EXPERIMENTAL_SRS
152   NULL,        /* srs */
153   NULL,        /* srs_alias */
154   NULL,        /* srs_condition */
155   NULL,        /* srs_dbinsert */
156   NULL,        /* srs_dbselect */
157 #endif
158   022,         /* modemask */
159   RDO_REWRITE | RDO_PREPEND_HOME, /* bit_options */
160   FALSE,       /* check_ancestor */
161   TRUE_UNSET,  /* check_owner */
162   TRUE_UNSET,  /* check_group */
163   FALSE,       /* forbid_file */
164   FALSE,       /* forbid_filter_reply */
165   FALSE,       /* forbid_pipe */
166   FALSE,       /* forbid_smtp_code */
167   FALSE,       /* hide_child_in_errmsg */
168   FALSE,       /* one_time */
169   FALSE,       /* qualify_preserve_domain */
170   FALSE        /* skip_syntax_errors */
171 };
172
173
174
175 /*************************************************
176 *          Initialization entry point            *
177 *************************************************/
178
179 /* Called for each instance, after its options have been read, to enable
180 consistency checks to be done, or anything else that needs to be set up. */
181
182 void redirect_router_init(router_instance *rblock)
183 {
184 redirect_router_options_block *ob =
185   (redirect_router_options_block *)(rblock->options_block);
186
187 /* Either file or data must be set, but not both */
188
189 if ((ob->file == NULL) == (ob->data == NULL))
190   log_write(0, LOG_PANIC_DIE|LOG_CONFIG_FOR, "%s router:\n  "
191     "%sone of \"file\" or \"data\" must be specified",
192     rblock->name, (ob->file == NULL)? "" : "only ");
193
194 /* Onetime aliases can only be real addresses. Headers can't be manipulated.
195 The combination of one_time and unseen is not allowed. We can't check the
196 expansion of "unseen" here, but we assume that if it is set to anything other
197 than false, there is likely to be a problem. */
198
199 if (ob->one_time)
200   {
201   ob->forbid_pipe = ob->forbid_file = ob->forbid_filter_reply = TRUE;
202   if (rblock->extra_headers || rblock->remove_headers)
203     log_write(0, LOG_PANIC_DIE|LOG_CONFIG_FOR, "%s router:\n  "
204       "\"headers_add\" and \"headers_remove\" are not permitted with "
205       "\"one_time\"", rblock->name);
206   if (rblock->unseen || rblock->expand_unseen)
207     log_write(0, LOG_PANIC_DIE|LOG_CONFIG_FOR, "%s router:\n  "
208       "\"unseen\" may not be used with \"one_time\"", rblock->name);
209   }
210
211 /* The defaults for check_owner and check_group depend on other settings. The
212 defaults are: Check the owner if check_local_user or owners is set; check the
213 group if check_local_user is set without a restriction on the group write bit,
214 or if owngroups is set. */
215
216 if (ob->check_owner == TRUE_UNSET)
217   ob->check_owner = rblock->check_local_user ||
218                     (ob->owners && ob->owners[0] != 0);
219
220 if (ob->check_group == TRUE_UNSET)
221   ob->check_group = (rblock->check_local_user && (ob->modemask & 020) == 0) ||
222                     (ob->owngroups != NULL && ob->owngroups[0] != 0);
223
224 /* If explicit qualify domain set, the preserve option is locked out */
225
226 if (ob->qualify_domain && ob->qualify_preserve_domain)
227   log_write(0, LOG_PANIC_DIE|LOG_CONFIG_FOR, "%s router:\n  "
228     "only one of \"qualify_domain\" or \"qualify_preserve_domain\" must be set",
229     rblock->name);
230
231 /* If allow_filter is set, either user or check_local_user must be set. */
232
233 if (!rblock->check_local_user &&
234     !rblock->uid_set &&
235     rblock->expand_uid == NULL &&
236     (ob->bit_options & RDO_FILTER) != 0)
237   log_write(0, LOG_PANIC_DIE|LOG_CONFIG_FOR, "%s router:\n  "
238     "\"user\" or \"check_local_user\" must be set with \"allow_filter\"",
239     rblock->name);
240 }
241
242
243
244 /*************************************************
245 *       Get errors address and header mods       *
246 *************************************************/
247
248 /* This function is called when new addresses are generated, in order to
249 sort out errors address and header modifications. We put the errors address
250 into the parent address (even though it is never used from there because that
251 address is never transported) so that it can be retrieved if any of the
252 children gets routed by an "unseen" router. The clone of the child that is
253 passed on must have the original errors_address value.
254
255 Arguments:
256   rblock               the router control block
257   addr                 the address being routed
258   verify               v_none/v_recipient/v_sender/v_expn
259   addr_prop            point to the propagated block, which is where the
260                          new values are to be placed
261
262 Returns:    the result of rf_get_errors_address() or rf_get_munge_headers(),
263             which is either OK or DEFER
264 */
265
266 static int
267 sort_errors_and_headers(router_instance *rblock, address_item *addr,
268   int verify, address_item_propagated *addr_prop)
269 {
270 int frc = rf_get_errors_address(addr, rblock, verify,
271   &addr_prop->errors_address);
272 if (frc != OK) return frc;
273 addr->prop.errors_address = addr_prop->errors_address;
274 return rf_get_munge_headers(addr, rblock, &addr_prop->extra_headers,
275   &addr_prop->remove_headers);
276 }
277
278
279
280 /*************************************************
281 *    Process a set of generated new addresses    *
282 *************************************************/
283
284 /* This function sets up a set of newly generated child addresses and puts them
285 on the new address chain. Copy in the uid, gid and permission flags for use by
286 pipes and files, set the parent, and "or" its af_ignore_error flag. Also record
287 the setting for any starting router.
288
289 If the generated address is the same as one of its ancestors, and the
290 check_ancestor flag is set, do not use this generated address, but replace it
291 with a copy of the input address. This is to cope with cases where A is aliased
292 to B and B has a .forward file pointing to A, though it is usually set on the
293 forwardfile rather than the aliasfile. We can't just pass on the old
294 address by returning FAIL, because it must act as a general parent for
295 generated addresses, and only get marked "done" when all its children are
296 delivered.
297
298 Arguments:
299   rblock                  router block
300   addr_new                new address chain
301   addr                    original address
302   generated               list of generated addresses
303   addr_prop               the propagated block, containing the errors_address,
304                             header modification stuff, and address_data
305   ugidptr                 points to uid/gid data for files, pipes, autoreplies
306   pw                      password entry, set if ob->check_local_user is TRUE
307
308 Returns:         nothing
309 */
310
311 static void
312 add_generated(router_instance *rblock, address_item **addr_new,
313   address_item *addr, address_item *generated,
314   address_item_propagated *addr_prop, ugid_block *ugidptr, struct passwd *pw)
315 {
316 redirect_router_options_block *ob =
317   (redirect_router_options_block *)(rblock->options_block);
318
319 while (generated)
320   {
321   address_item *parent;
322   address_item *next = generated;
323   uschar *errors_address = next->prop.errors_address;
324
325   generated = next->next;
326   next->parent = addr;
327   next->start_router = rblock->redirect_router;
328   if (addr->child_count == USHRT_MAX)
329     log_write(0, LOG_MAIN|LOG_PANIC_DIE, "%s router generated more than %d "
330       "child addresses for <%s>", rblock->name, USHRT_MAX, addr->address);
331   addr->child_count++;
332
333   next->next = *addr_new;
334   *addr_new = next;
335
336   /* Don't do the "one_time" thing for the first pass of a 2-stage queue run. */
337
338   if (ob->one_time && !f.queue_2stage)
339     {
340     for (parent = addr; parent->parent; parent = parent->parent) ;
341     next->onetime_parent = parent->address;
342     }
343
344   if (ob->hide_child_in_errmsg) setflag(next, af_hide_child);
345
346   /* If check_ancestor is set, we want to know if any ancestor of this address
347   is the address we are about to generate. The check must be done caselessly
348   unless the ancestor was routed by a case-sensitive router. */
349
350   if (ob->check_ancestor)
351     for (parent = addr; parent; parent = parent->parent)
352       if ((parent->router && parent->router->caseful_local_part
353            ? Ustrcmp(next->address, parent->address)
354            : strcmpic(next->address, parent->address)
355           ) == 0)
356         {
357         DEBUG(D_route) debug_printf("generated parent replaced by child\n");
358         next->address = string_copy(addr->address);
359         break;
360         }
361
362   /* A user filter may, under some circumstances, set up an errors address.
363   If so, we must take care to re-instate it when we copy in the propagated
364   data so that it overrides any errors_to setting on the router. */
365
366     {
367     BOOL ignore_error = next->prop.ignore_error;
368     next->prop = *addr_prop;
369     next->prop.ignore_error = ignore_error || addr->prop.ignore_error;
370     }
371   if (errors_address) next->prop.errors_address = errors_address;
372
373   /* For pipes, files, and autoreplies, record this router as handling them,
374   because they don't go through the routing process again. Then set up uid,
375   gid, home and current directories for transporting. */
376
377   if (testflag(next, af_pfr))
378     {
379     next->router = rblock;
380     rf_set_ugid(next, ugidptr);   /* Will contain pw values if not overridden */
381
382     /* When getting the home directory out of the password information, wrap it
383     in \N...\N to avoid expansion later. In Cygwin, home directories can
384     contain $ characters. */
385
386     if (rblock->home_directory != NULL)
387       next->home_dir = rblock->home_directory;
388     else if (rblock->check_local_user)
389       next->home_dir = string_sprintf("\\N%s\\N", pw->pw_dir);
390     else if (rblock->router_home_directory != NULL &&
391              testflag(addr, af_home_expanded))
392       {
393       next->home_dir = deliver_home;
394       setflag(next, af_home_expanded);
395       }
396
397     next->current_dir = rblock->current_directory;
398
399     /* Permission options */
400
401     if (!ob->forbid_pipe) setflag(next, af_allow_pipe);
402     if (!ob->forbid_file) setflag(next, af_allow_file);
403     if (!ob->forbid_filter_reply) setflag(next, af_allow_reply);
404
405     /* If the transport setting fails, the error gets picked up at the outer
406     level from the setting of basic_errno in the address. */
407
408     if (next->address[0] == '|')
409       {
410       address_pipe = next->address;
411       if (rf_get_transport(ob->pipe_transport_name, &(ob->pipe_transport),
412           next, rblock->name, US"pipe_transport"))
413         next->transport = ob->pipe_transport;
414       address_pipe = NULL;
415       }
416     else if (next->address[0] == '>')
417       {
418       if (rf_get_transport(ob->reply_transport_name, &(ob->reply_transport),
419           next, rblock->name, US"reply_transport"))
420         next->transport = ob->reply_transport;
421       }
422     else  /* must be file or directory */
423       {
424       int len = Ustrlen(next->address);
425       address_file = next->address;
426       if (next->address[len-1] == '/')
427         {
428         if (rf_get_transport(ob->directory_transport_name,
429             &(ob->directory_transport), next, rblock->name,
430             US"directory_transport"))
431           next->transport = ob->directory_transport;
432         }
433       else
434         {
435         if (rf_get_transport(ob->file_transport_name, &(ob->file_transport),
436             next, rblock->name, US"file_transport"))
437           next->transport = ob->file_transport;
438         }
439       address_file = NULL;
440       }
441     }
442
443 #ifdef SUPPORT_I18N
444     if (!next->prop.utf8_msg)
445       next->prop.utf8_msg = string_is_utf8(next->address)
446         || (sender_address && string_is_utf8(sender_address));
447 #endif
448
449   DEBUG(D_route)
450     {
451     debug_printf("%s router generated %s\n  %serrors_to=%s transport=%s\n",
452       rblock->name,
453       next->address,
454       testflag(next, af_pfr)? "pipe, file, or autoreply\n  " : "",
455       next->prop.errors_address,
456       (next->transport == NULL)? US"NULL" : next->transport->name);
457
458     if (testflag(next, af_uid_set))
459       debug_printf("  uid=%ld ", (long int)(next->uid));
460     else
461       debug_printf("  uid=unset ");
462
463     if (testflag(next, af_gid_set))
464       debug_printf("gid=%ld ", (long int)(next->gid));
465     else
466       debug_printf("gid=unset ");
467
468 #ifdef SUPPORT_I18N
469     if (next->prop.utf8_msg) debug_printf("utf8 ");
470 #endif
471
472     debug_printf("home=%s\n", next->home_dir);
473     }
474   }
475 }
476
477
478 /*************************************************
479 *              Main entry point                  *
480 *************************************************/
481
482 /* See local README for interface description. This router returns:
483
484 DECLINE
485   . empty address list, or filter did nothing significant
486
487 DEFER
488   . verifying the errors address caused a deferment or a big disaster such
489       as an expansion failure (rf_get_errors_address)
490   . expanding a headers_{add,remove} string caused a deferment or another
491       expansion error (rf_get_munge_headers)
492   . :defer: or "freeze" in a filter
493   . error in address list or filter
494   . skipped syntax errors, but failed to send the message
495
496 DISCARD
497   . address was :blackhole:d or "seen finish"ed
498
499 FAIL
500   . :fail:
501
502 OK
503   . new addresses added to addr_new
504 */
505
506 int redirect_router_entry(
507   router_instance *rblock,        /* data for this instantiation */
508   address_item *addr,             /* address we are working on */
509   struct passwd *pw,              /* passwd entry after check_local_user */
510   int verify,                     /* v_none/v_recipient/v_sender/v_expn */
511   address_item **addr_local,      /* add it to this if it's local */
512   address_item **addr_remote,     /* add it to this if it's remote */
513   address_item **addr_new,        /* put new addresses on here */
514   address_item **addr_succeed)    /* put old address here on success */
515 {
516 redirect_router_options_block *ob =
517   (redirect_router_options_block *)(rblock->options_block);
518 address_item *generated = NULL;
519 const uschar *save_qualify_domain_recipient = qualify_domain_recipient;
520 uschar *discarded = US"discarded";
521 address_item_propagated addr_prop;
522 error_block *eblock = NULL;
523 ugid_block ugid;
524 redirect_block redirect;
525 int filtertype = FILTER_UNSET;
526 int yield = OK;
527 int options = ob->bit_options;
528 int frc = 0;
529 int xrc = 0;
530
531 addr_local = addr_local;     /* Keep picky compilers happy */
532 addr_remote = addr_remote;
533
534 /* Initialize the data to be propagated to the children */
535
536 addr_prop.address_data = deliver_address_data;
537 addr_prop.domain_data = deliver_domain_data;
538 addr_prop.localpart_data = deliver_localpart_data;
539 addr_prop.errors_address = NULL;
540 addr_prop.extra_headers = NULL;
541 addr_prop.remove_headers = NULL;
542 addr_prop.variables = NULL;
543 tree_dup((tree_node **)&addr_prop.variables, addr->prop.variables);
544
545 #ifdef EXPERIMENTAL_SRS
546 addr_prop.srs_sender = NULL;
547 #endif
548 #ifdef SUPPORT_I18N
549 addr_prop.utf8_msg = addr->prop.utf8_msg;
550 addr_prop.utf8_downcvt = addr->prop.utf8_downcvt;
551 addr_prop.utf8_downcvt_maybe = addr->prop.utf8_downcvt_maybe;
552 #endif
553
554
555 /* When verifying and testing addresses, the "logwrite" command in filters
556 must be bypassed. */
557
558 if (verify == v_none && !f.address_test_mode) options |= RDO_REALLOG;
559
560 /* Sort out the fixed or dynamic uid/gid. This uid is used (a) for reading the
561 file (and interpreting a filter) and (b) for running the transports for
562 generated file and pipe addresses. It is not (necessarily) the same as the uids
563 that may own the file. Exim panics if an expanded string is not a number and
564 can't be found in the password file. Other errors set the freezing bit. */
565
566 if (!rf_get_ugid(rblock, addr, &ugid)) return DEFER;
567
568 if (!ugid.uid_set && pw != NULL)
569   {
570   ugid.uid = pw->pw_uid;
571   ugid.uid_set = TRUE;
572   }
573
574 if (!ugid.gid_set && pw != NULL)
575   {
576   ugid.gid = pw->pw_gid;
577   ugid.gid_set = TRUE;
578   }
579
580 #ifdef EXPERIMENTAL_SRS
581   /* Perform SRS on recipient/return-path as required  */
582
583   if(ob->srs != NULL)
584   {
585     BOOL usesrs = TRUE;
586
587     if(ob->srs_condition != NULL)
588       usesrs = expand_check_condition(ob->srs_condition, "srs_condition expansion failed", NULL);
589
590     if(usesrs)
591     {
592       int srs_action = 0, n_srs;
593       uschar *res;
594       uschar *usedomain;
595
596       /* What are we doing? */
597       if(Ustrcmp(ob->srs, "forward") == 0)
598         srs_action = 1;
599       else if(Ustrcmp(ob->srs, "reverseandforward") == 0)
600       {
601         srs_action = 3;
602
603         if((ob->srs_dbinsert == NULL) ^ (ob->srs_dbselect == NULL))
604           return DEFER;
605       }
606       else if(Ustrcmp(ob->srs, "reverse") == 0)
607         srs_action = 2;
608
609       /* Reverse SRS */
610       if(srs_action & 2)
611       {
612         srs_orig_recipient = addr->address;
613
614         eximsrs_init();
615         if(ob->srs_dbselect)
616           eximsrs_db_set(TRUE, ob->srs_dbselect);
617 /* Comment this out for now...
618 //        else
619 //          eximsrs_db_set(TRUE, NULL);
620 */
621
622         if((n_srs = eximsrs_reverse(&res, addr->address)) == OK)
623         {
624           srs_recipient = res;
625           DEBUG(D_any)
626             debug_printf("SRS (reverse): Recipient '%s' rewritten to '%s'\n", srs_orig_recipient, srs_recipient);
627         }
628
629         eximsrs_done();
630
631         if(n_srs != OK)
632           return n_srs;
633       }
634
635       /* Forward SRS */
636       /* No point in actually performing SRS if we are just verifying a recipient */
637       if((srs_action & 1) && verify == v_none &&
638          (sender_address ? sender_address[0] != 0 : FALSE))
639       {
640
641         srs_orig_sender = sender_address;
642         eximsrs_init();
643         if(ob->srs_dbinsert)
644           eximsrs_db_set(FALSE, ob->srs_dbinsert);
645 /* Comment this out for now...
646 //        else
647 //          eximsrs_db_set(FALSE, NULL);
648 */
649
650         if (!(usedomain = ob->srs_alias ? expand_string(ob->srs_alias) : NULL))
651           usedomain = string_copy(deliver_domain);
652
653         if((n_srs = eximsrs_forward(&res, sender_address, usedomain)) == OK)
654         {
655           addr_prop.srs_sender = res;
656           DEBUG(D_any)
657             debug_printf("SRS (forward): Sender '%s' rewritten to '%s'\n", srs_orig_sender, res);
658         }
659
660         eximsrs_done();
661
662         if(n_srs != OK)
663           return n_srs;
664       }
665     }
666   }
667 #endif
668
669 /* Call the function that interprets redirection data, either inline or from a
670 file. This is a separate function so that the system filter can use it. It will
671 run the function in a subprocess if necessary. If qualify_preserve_domain is
672 set, temporarily reset qualify_domain_recipient to the current domain so that
673 any unqualified addresses get qualified with the same domain as the incoming
674 address. Otherwise, if a local qualify_domain is provided, set that up. */
675
676 if (ob->qualify_preserve_domain)
677   qualify_domain_recipient = addr->domain;
678 else if (ob->qualify_domain)
679   {
680   uschar *new_qdr = rf_expand_data(addr, ob->qualify_domain, &xrc);
681   if (!new_qdr) return xrc;
682   qualify_domain_recipient = new_qdr;
683   }
684
685 redirect.owners = ob->owners;
686 redirect.owngroups = ob->owngroups;
687 redirect.modemask = ob->modemask;
688 redirect.check_owner = ob->check_owner;
689 redirect.check_group = ob->check_group;
690 redirect.pw = pw;
691
692 redirect.string = (redirect.isfile = (ob->file != NULL))
693   ? ob->file : ob->data;
694
695 frc = rda_interpret(&redirect, options, ob->include_directory,
696   ob->sieve_vacation_directory, ob->sieve_enotify_mailto_owner,
697   ob->sieve_useraddress, ob->sieve_subaddress, &ugid, &generated,
698   &(addr->message), ob->skip_syntax_errors? &eblock : NULL, &filtertype,
699   string_sprintf("%s router (recipient is %s)", rblock->name, addr->address));
700
701 qualify_domain_recipient = save_qualify_domain_recipient;
702
703 /* Handle exceptional returns from filtering or processing an address list.
704 For FAIL and FREEZE we honour any previously set up deliveries by a filter. */
705
706 switch (frc)
707   {
708   case FF_NONEXIST:
709     addr->message = addr->user_message = NULL;
710     return DECLINE;
711
712   case FF_BLACKHOLE:
713     DEBUG(D_route) debug_printf("address :blackhole:d\n");
714     generated = NULL;
715     discarded = US":blackhole:";
716     frc = FF_DELIVERED;
717     break;
718
719     /* FF_DEFER and FF_FAIL can arise only as a result of explicit commands
720     (:defer: or :fail: in an alias file or "fail" in a filter). If a configured
721     message was supplied, allow it to be included in an SMTP response after
722     verifying. Remove any SMTP code if it is not allowed. */
723
724   case FF_DEFER:
725     yield = DEFER;
726     goto SORT_MESSAGE;
727
728   case FF_FAIL:
729     if ((xrc = sort_errors_and_headers(rblock, addr, verify, &addr_prop)) != OK)
730       return xrc;
731     add_generated(rblock, addr_new, addr, generated, &addr_prop, &ugid, pw);
732     yield = FAIL;
733
734     SORT_MESSAGE:
735     if (!addr->message)
736       addr->message = yield == FAIL ? US"forced rejection" : US"forced defer";
737     else
738       {
739       int ovector[3];
740       if (ob->forbid_smtp_code &&
741           pcre_exec(regex_smtp_code, NULL, CS addr->message,
742             Ustrlen(addr->message), 0, PCRE_EOPT,
743             ovector, sizeof(ovector)/sizeof(int)) >= 0)
744         {
745         DEBUG(D_route) debug_printf("SMTP code at start of error message "
746           "is ignored because forbid_smtp_code is set\n");
747         addr->message += ovector[1];
748         }
749       addr->user_message = addr->message;
750       setflag(addr, af_pass_message);
751       }
752     return yield;
753
754     /* As in the case of a system filter, a freeze does not happen after a manual
755     thaw. In case deliveries were set up by the filter, we set the child count
756     high so that their completion does not mark the original address done. */
757
758   case FF_FREEZE:
759     if (!f.deliver_manual_thaw)
760       {
761       if ((xrc = sort_errors_and_headers(rblock, addr, verify, &addr_prop))
762         != OK) return xrc;
763       add_generated(rblock, addr_new, addr, generated, &addr_prop, &ugid, pw);
764       if (addr->message == NULL) addr->message = US"frozen by filter";
765       addr->special_action = SPECIAL_FREEZE;
766       addr->child_count = 9999;
767       return DEFER;
768       }
769     frc = FF_NOTDELIVERED;
770     break;
771
772     /* Handle syntax errors and :include: failures and lookup defers */
773
774   case FF_ERROR:
775   case FF_INCLUDEFAIL:
776
777     /* If filtertype is still FILTER_UNSET, it means that the redirection data
778     was never inspected, so the error was an expansion failure or failure to open
779     the file, or whatever. In these cases, the existing error message is probably
780     sufficient. */
781
782     if (filtertype == FILTER_UNSET) return DEFER;
783
784     /* If it was a filter and skip_syntax_errors is set, we want to set up
785     the error message so that it can be logged and mailed to somebody. */
786
787     if (filtertype != FILTER_FORWARD && ob->skip_syntax_errors)
788       {
789       eblock = store_get(sizeof(error_block), FALSE);
790       eblock->next = NULL;
791       eblock->text1 = addr->message;
792       eblock->text2 = NULL;
793       addr->message = addr->user_message = NULL;
794       }
795
796     /* Otherwise set up the error for the address and defer. */
797
798     else
799       {
800       addr->basic_errno = ERRNO_BADREDIRECT;
801       addr->message = string_sprintf("error in %s %s: %s",
802         filtertype == FILTER_FORWARD ? "redirect" : "filter",
803         ob->data ? "data" : "file",
804         addr->message);
805       return DEFER;
806       }
807   }
808
809
810 /* Yield is either FF_DELIVERED (significant action) or FF_NOTDELIVERED (no
811 significant action). Before dealing with these, however, we must handle the
812 effect of skip_syntax_errors.
813
814 If skip_syntax_errors was set and there were syntax errors in an address list,
815 error messages will be present in eblock. Log them and send a message if so
816 configured. We cannot do this earlier, because the error message must not be
817 sent as the local user. If there were no valid addresses, generated will be
818 NULL. In this case, the router declines.
819
820 For a filter file, the error message has been fudged into an eblock. After
821 dealing with it, the router declines. */
822
823 if (eblock != NULL)
824   {
825   if (!moan_skipped_syntax_errors(
826         rblock->name,                            /* For message content */
827         eblock,                                  /* Ditto */
828         (verify != v_none || f.address_test_mode)?
829           NULL : ob->syntax_errors_to,           /* Who to mail */
830         generated != NULL,                       /* True if not all failed */
831         ob->syntax_errors_text))                 /* Custom message */
832     return DEFER;
833
834   if (filtertype != FILTER_FORWARD || generated == NULL)
835     {
836     addr->message = US"syntax error in redirection data";
837     return DECLINE;
838     }
839   }
840
841 /* Sort out the errors address and any header modifications, and handle the
842 generated addresses, if any. If there are no generated addresses, we must avoid
843 calling sort_errors_and_headers() in case this router declines - that function
844 may modify the errors_address field in the current address, and we don't want
845 to do that for a decline. */
846
847 if (generated != NULL)
848   {
849   if ((xrc = sort_errors_and_headers(rblock, addr, verify, &addr_prop)) != OK)
850     return xrc;
851   add_generated(rblock, addr_new, addr, generated, &addr_prop, &ugid, pw);
852   }
853
854 /* FF_DELIVERED with no generated addresses is what we get when an address list
855 contains :blackhole: or a filter contains "seen finish" without having
856 generated anything. Log what happened to this address, and return DISCARD. */
857
858 if (frc == FF_DELIVERED)
859   {
860   if (generated == NULL && verify == v_none && !f.address_test_mode)
861     {
862     log_write(0, LOG_MAIN, "=> %s <%s> R=%s", discarded, addr->address,
863       rblock->name);
864     yield = DISCARD;
865     }
866   }
867
868 /* For an address list, FF_NOTDELIVERED always means that no addresses were
869 generated. For a filter, addresses may or may not have been generated. If none
870 were, it's the same as an empty address list, and the router declines. However,
871 if addresses were generated, we can't just decline because successful delivery
872 of the base address gets it marked "done", so deferred generated addresses
873 never get tried again. We have to generate a new version of the base address,
874 as if there were a "deliver" command in the filter file, with the original
875 address as parent. */
876
877 else
878   {
879   address_item *next;
880
881   if (generated == NULL) return DECLINE;
882
883   next = deliver_make_addr(addr->address, FALSE);
884   next->parent = addr;
885   addr->child_count++;
886   next->next = *addr_new;
887   *addr_new = next;
888
889   /* Set the data that propagates. */
890
891   next->prop = addr_prop;
892
893   DEBUG(D_route) debug_printf("%s router autogenerated %s\n%s%s%s",
894     rblock->name,
895     next->address,
896     (addr_prop.errors_address != NULL)? "  errors to " : "",
897     (addr_prop.errors_address != NULL)? addr_prop.errors_address : US"",
898     (addr_prop.errors_address != NULL)? "\n" : "");
899   }
900
901 /* Control gets here only when the address has been completely handled. Put the
902 original address onto the succeed queue so that any retry items that get
903 attached to it get processed. */
904
905 addr->next = *addr_succeed;
906 *addr_succeed = addr;
907
908 return yield;
909 }
910
911 #endif   /*!MACRO_PREDEF*/
912 /* End of routers/redirect.c */