Auths: fix cyrus-sasl driver for gssapi use. Bug 2524
[exim.git] / src / src / routers / redirect.c
CommitLineData
0756eb3c
PH
1/*************************************************
2* Exim - an Internet mail transport agent *
3*************************************************/
4
f9ba5e22 5/* Copyright (c) University of Cambridge 1995 - 2018 */
0756eb3c
PH
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. */
13a4b4c1 16#define LOFF(field) OPT_OFF(redirect_router_options_block, field)
0756eb3c
PH
17
18optionlist redirect_router_options[] = {
19 { "allow_defer", opt_bit | (RDON_DEFER << 16),
13a4b4c1 20 LOFF(bit_options) },
0756eb3c 21 { "allow_fail", opt_bit | (RDON_FAIL << 16),
13a4b4c1 22 LOFF(bit_options) },
0756eb3c 23 { "allow_filter", opt_bit | (RDON_FILTER << 16),
13a4b4c1 24 LOFF(bit_options) },
0756eb3c 25 { "allow_freeze", opt_bit | (RDON_FREEZE << 16),
13a4b4c1
JH
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
4608d683 35 { "filter_prepend_home",opt_bit | (RDON_PREPEND_HOME << 16),
13a4b4c1 36 LOFF(bit_options) },
0756eb3c 37 { "forbid_blackhole", opt_bit | (RDON_BLACKHOLE << 16),
13a4b4c1 38 LOFF(bit_options) },
23c7ff99 39 { "forbid_exim_filter", opt_bit | (RDON_EXIM_FILTER << 16),
13a4b4c1 40 LOFF(bit_options) },
0756eb3c 41 { "forbid_file", opt_bool,
13a4b4c1 42 LOFF(forbid_file) },
1a46a8c5 43 { "forbid_filter_dlfunc", opt_bit | (RDON_DLFUNC << 16),
13a4b4c1 44 LOFF(bit_options) },
0756eb3c 45 { "forbid_filter_existstest", opt_bit | (RDON_EXISTS << 16),
13a4b4c1 46 LOFF(bit_options) },
0756eb3c 47 { "forbid_filter_logwrite",opt_bit | (RDON_LOG << 16),
13a4b4c1 48 LOFF(bit_options) },
0756eb3c 49 { "forbid_filter_lookup", opt_bit | (RDON_LOOKUP << 16),
13a4b4c1 50 LOFF(bit_options) },
0756eb3c 51 { "forbid_filter_perl", opt_bit | (RDON_PERL << 16),
13a4b4c1 52 LOFF(bit_options) },
0756eb3c 53 { "forbid_filter_readfile", opt_bit | (RDON_READFILE << 16),
13a4b4c1 54 LOFF(bit_options) },
0756eb3c 55 { "forbid_filter_readsocket", opt_bit | (RDON_READSOCK << 16),
13a4b4c1 56 LOFF(bit_options) },
0756eb3c 57 { "forbid_filter_reply",opt_bool,
13a4b4c1 58 LOFF(forbid_filter_reply) },
0756eb3c 59 { "forbid_filter_run", opt_bit | (RDON_RUN << 16),
13a4b4c1 60 LOFF(bit_options) },
0756eb3c 61 { "forbid_include", opt_bit | (RDON_INCLUDE << 16),
13a4b4c1 62 LOFF(bit_options) },
0756eb3c 63 { "forbid_pipe", opt_bool,
13a4b4c1 64 LOFF(forbid_pipe) },
23c7ff99 65 { "forbid_sieve_filter",opt_bit | (RDON_SIEVE_FILTER << 16),
13a4b4c1 66 LOFF(bit_options) },
a5bd321b 67 { "forbid_smtp_code", opt_bool,
13a4b4c1 68 LOFF(forbid_smtp_code) },
0756eb3c 69 { "hide_child_in_errmsg", opt_bool,
13a4b4c1 70 LOFF( hide_child_in_errmsg) },
0756eb3c 71 { "ignore_eacces", opt_bit | (RDON_EACCES << 16),
13a4b4c1 72 LOFF(bit_options) },
0756eb3c 73 { "ignore_enotdir", opt_bit | (RDON_ENOTDIR << 16),
13a4b4c1
JH
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
0756eb3c 87 { "rewrite", opt_bit | (RDON_REWRITE << 16),
13a4b4c1
JH
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) },
8523533c 95#ifdef EXPERIMENTAL_SRS
13a4b4c1
JH
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) },
8523533c 101#endif
13a4b4c1
JH
102 { "syntax_errors_text", opt_stringptr, LOFF(syntax_errors_text) },
103 { "syntax_errors_to", opt_stringptr, LOFF(syntax_errors_to) }
0756eb3c
PH
104};
105
106/* Size of the options list. An extern variable has to be used so that its
107address can appear in the tables drtables.c. */
108
109int redirect_router_options_count =
110 sizeof(redirect_router_options)/sizeof(optionlist);
111
d185889f
JH
112
113#ifdef MACRO_PREDEF
114
115/* Dummy entries */
116redirect_router_options_block redirect_router_option_defaults = {0};
117void redirect_router_init(router_instance *rblock) {}
118int 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,
cab0c277 121 address_item **addr_succeed) {return 0;}
d185889f
JH
122
123#else /*!MACRO_PREDEF*/
124
125
126
0756eb3c
PH
127/* Default private options block for the redirect router. */
128
129redirect_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 */
e4a89c47
PH
142 NULL, /* sieve_subaddress */
143 NULL, /* sieve_useraddress */
0756eb3c 144 NULL, /* sieve_vacation_directory */
efd9a422 145 NULL, /* sieve_enotify_mailto_owner */
0756eb3c
PH
146 NULL, /* syntax_errors_text */
147 NULL, /* syntax_errors_to */
148 NULL, /* qualify_domain */
149 NULL, /* owners */
150 NULL, /* owngroups */
8523533c
TK
151#ifdef EXPERIMENTAL_SRS
152 NULL, /* srs */
8523533c 153 NULL, /* srs_alias */
384152a6
TK
154 NULL, /* srs_condition */
155 NULL, /* srs_dbinsert */
156 NULL, /* srs_dbselect */
8523533c 157#endif
0756eb3c 158 022, /* modemask */
4608d683 159 RDO_REWRITE | RDO_PREPEND_HOME, /* bit_options */
0756eb3c
PH
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 */
a5bd321b 166 FALSE, /* forbid_smtp_code */
0756eb3c
PH
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
180consistency checks to be done, or anything else that needs to be set up. */
181
182void redirect_router_init(router_instance *rblock)
183{
184redirect_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
189if ((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
7f45268c
PH
194/* Onetime aliases can only be real addresses. Headers can't be manipulated.
195The combination of one_time and unseen is not allowed. We can't check the
196expansion of "unseen" here, but we assume that if it is set to anything other
197than false, there is likely to be a problem. */
0756eb3c
PH
198
199if (ob->one_time)
200 {
201 ob->forbid_pipe = ob->forbid_file = ob->forbid_filter_reply = TRUE;
acec9514 202 if (rblock->extra_headers || rblock->remove_headers)
0756eb3c
PH
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);
acec9514 206 if (rblock->unseen || rblock->expand_unseen)
7f45268c
PH
207 log_write(0, LOG_PANIC_DIE|LOG_CONFIG_FOR, "%s router:\n "
208 "\"unseen\" may not be used with \"one_time\"", rblock->name);
0756eb3c
PH
209 }
210
211/* The defaults for check_owner and check_group depend on other settings. The
212defaults are: Check the owner if check_local_user or owners is set; check the
213group if check_local_user is set without a restriction on the group write bit,
214or if owngroups is set. */
215
216if (ob->check_owner == TRUE_UNSET)
217 ob->check_owner = rblock->check_local_user ||
acec9514 218 (ob->owners && ob->owners[0] != 0);
0756eb3c
PH
219
220if (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
acec9514 226if (ob->qualify_domain && ob->qualify_preserve_domain)
0756eb3c
PH
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
233if (!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
249sort out errors address and header modifications. We put the errors address
250into the parent address (even though it is never used from there because that
251address is never transported) so that it can be retrieved if any of the
252children gets routed by an "unseen" router. The clone of the child that is
253passed on must have the original errors_address value.
254
255Arguments:
256 rblock the router control block
257 addr the address being routed
fd6de02e 258 verify v_none/v_recipient/v_sender/v_expn
0756eb3c
PH
259 addr_prop point to the propagated block, which is where the
260 new values are to be placed
261
262Returns: the result of rf_get_errors_address() or rf_get_munge_headers(),
263 which is either OK or DEFER
264*/
265
266static int
267sort_errors_and_headers(router_instance *rblock, address_item *addr,
fd6de02e 268 int verify, address_item_propagated *addr_prop)
0756eb3c
PH
269{
270int frc = rf_get_errors_address(addr, rblock, verify,
d43cbe25 271 &addr_prop->errors_address);
0756eb3c 272if (frc != OK) return frc;
d43cbe25
JH
273addr->prop.errors_address = addr_prop->errors_address;
274return rf_get_munge_headers(addr, rblock, &addr_prop->extra_headers,
275 &addr_prop->remove_headers);
0756eb3c
PH
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
285on the new address chain. Copy in the uid, gid and permission flags for use by
286pipes and files, set the parent, and "or" its af_ignore_error flag. Also record
287the setting for any starting router.
288
289If the generated address is the same as one of its ancestors, and the
290check_ancestor flag is set, do not use this generated address, but replace it
291with a copy of the input address. This is to cope with cases where A is aliased
292to B and B has a .forward file pointing to A, though it is usually set on the
293forwardfile rather than the aliasfile. We can't just pass on the old
294address by returning FAIL, because it must act as a general parent for
295generated addresses, and only get marked "done" when all its children are
296delivered.
297
298Arguments:
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
308Returns: nothing
309*/
310
311static void
312add_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{
316redirect_router_options_block *ob =
317 (redirect_router_options_block *)(rblock->options_block);
318
d1f9fb42 319while (generated)
0756eb3c
PH
320 {
321 address_item *parent;
322 address_item *next = generated;
d43cbe25 323 uschar *errors_address = next->prop.errors_address;
0756eb3c
PH
324
325 generated = next->next;
326 next->parent = addr;
0756eb3c 327 next->start_router = rblock->redirect_router;
82f90600 328 if (addr->child_count == USHRT_MAX)
4362ff0d 329 log_write(0, LOG_MAIN|LOG_PANIC_DIE, "%s router generated more than %d "
82f90600 330 "child addresses for <%s>", rblock->name, USHRT_MAX, addr->address);
0756eb3c
PH
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
8768d548 338 if (ob->one_time && !f.queue_2stage)
0756eb3c 339 {
d1f9fb42 340 for (parent = addr; parent->parent; parent = parent->parent) ;
0756eb3c
PH
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)
d1f9fb42
JH
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)
0756eb3c
PH
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 }
0756eb3c
PH
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
7eb0e5d2
JH
366 {
367 BOOL ignore_error = next->prop.ignore_error;
368 next->prop = *addr_prop;
a5853d7c 369 next->prop.ignore_error = ignore_error || addr->prop.ignore_error;
7eb0e5d2
JH
370 }
371 if (errors_address) next->prop.errors_address = errors_address;
0756eb3c
PH
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
8c5d388a 443#ifdef SUPPORT_I18N
e6532c4a
JH
444 if (!next->prop.utf8_msg)
445 next->prop.utf8_msg = string_is_utf8(next->address)
446 || (sender_address && string_is_utf8(sender_address));
f923454a
JH
447#endif
448
0756eb3c
PH
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 " : "",
d43cbe25 455 next->prop.errors_address,
0756eb3c
PH
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
8c5d388a 468#ifdef SUPPORT_I18N
3c8b3577 469 if (next->prop.utf8_msg) debug_printf("utf8 ");
f923454a
JH
470#endif
471
0756eb3c
PH
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
484DECLINE
485 . empty address list, or filter did nothing significant
486
487DEFER
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
496DISCARD
497 . address was :blackhole:d or "seen finish"ed
498
499FAIL
500 . :fail:
501
502OK
503 . new addresses added to addr_new
504*/
505
506int 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 */
fd6de02e 510 int verify, /* v_none/v_recipient/v_sender/v_expn */
0756eb3c
PH
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{
516redirect_router_options_block *ob =
517 (redirect_router_options_block *)(rblock->options_block);
518address_item *generated = NULL;
55414b25 519const uschar *save_qualify_domain_recipient = qualify_domain_recipient;
0756eb3c
PH
520uschar *discarded = US"discarded";
521address_item_propagated addr_prop;
522error_block *eblock = NULL;
523ugid_block ugid;
524redirect_block redirect;
525int filtertype = FILTER_UNSET;
526int yield = OK;
527int options = ob->bit_options;
528int frc = 0;
529int xrc = 0;
530
531addr_local = addr_local; /* Keep picky compilers happy */
532addr_remote = addr_remote;
533
534/* Initialize the data to be propagated to the children */
535
536addr_prop.address_data = deliver_address_data;
537addr_prop.domain_data = deliver_domain_data;
538addr_prop.localpart_data = deliver_localpart_data;
539addr_prop.errors_address = NULL;
540addr_prop.extra_headers = NULL;
541addr_prop.remove_headers = NULL;
b4f579d1
JH
542addr_prop.variables = NULL;
543tree_dup((tree_node **)&addr_prop.variables, addr->prop.variables);
0756eb3c 544
384152a6
TK
545#ifdef EXPERIMENTAL_SRS
546addr_prop.srs_sender = NULL;
547#endif
cb570b5e 548#ifdef SUPPORT_I18N
e6532c4a
JH
549addr_prop.utf8_msg = addr->prop.utf8_msg;
550addr_prop.utf8_downcvt = addr->prop.utf8_downcvt;
551addr_prop.utf8_downcvt_maybe = addr->prop.utf8_downcvt_maybe;
cb570b5e
JH
552#endif
553
384152a6 554
0756eb3c
PH
555/* When verifying and testing addresses, the "logwrite" command in filters
556must be bypassed. */
557
8768d548 558if (verify == v_none && !f.address_test_mode) options |= RDO_REALLOG;
0756eb3c
PH
559
560/* Sort out the fixed or dynamic uid/gid. This uid is used (a) for reading the
561file (and interpreting a filter) and (b) for running the transports for
562generated file and pipe addresses. It is not (necessarily) the same as the uids
563that may own the file. Exim panics if an expanded string is not a number and
564can't be found in the password file. Other errors set the freezing bit. */
565
566if (!rf_get_ugid(rblock, addr, &ugid)) return DEFER;
567
568if (!ugid.uid_set && pw != NULL)
569 {
570 ugid.uid = pw->pw_uid;
571 ugid.uid_set = TRUE;
572 }
573
574if (!ugid.gid_set && pw != NULL)
575 {
576 ugid.gid = pw->pw_gid;
577 ugid.gid_set = TRUE;
578 }
579
8523533c 580#ifdef EXPERIMENTAL_SRS
384152a6
TK
581 /* Perform SRS on recipient/return-path as required */
582
8523533c
TK
583 if(ob->srs != NULL)
584 {
585 BOOL usesrs = TRUE;
8e669ac1 586
8523533c
TK
587 if(ob->srs_condition != NULL)
588 usesrs = expand_check_condition(ob->srs_condition, "srs_condition expansion failed", NULL);
8e669ac1 589
8523533c 590 if(usesrs)
384152a6 591 {
5614ee86 592 int srs_action = 0, n_srs;
384152a6
TK
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)
8523533c 600 {
384152a6 601 srs_action = 3;
8e669ac1 602
384152a6
TK
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 {
8523533c 612 srs_orig_recipient = addr->address;
384152a6 613
8523533c 614 eximsrs_init();
384152a6
TK
615 if(ob->srs_dbselect)
616 eximsrs_db_set(TRUE, ob->srs_dbselect);
130e9641 617/* Comment this out for now...
384152a6
TK
618// else
619// eximsrs_db_set(TRUE, NULL);
130e9641 620*/
384152a6
TK
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)
8523533c 632 return n_srs;
384152a6
TK
633 }
634
635 /* Forward SRS */
636 /* No point in actually performing SRS if we are just verifying a recipient */
fd6de02e
PH
637 if((srs_action & 1) && verify == v_none &&
638 (sender_address ? sender_address[0] != 0 : FALSE))
384152a6
TK
639 {
640
641 srs_orig_sender = sender_address;
642 eximsrs_init();
643 if(ob->srs_dbinsert)
644 eximsrs_db_set(FALSE, ob->srs_dbinsert);
130e9641 645/* Comment this out for now...
384152a6
TK
646// else
647// eximsrs_db_set(FALSE, NULL);
130e9641 648*/
384152a6 649
dc8091e7
JH
650 if (!(usedomain = ob->srs_alias ? expand_string(ob->srs_alias) : NULL))
651 usedomain = string_copy(deliver_domain);
384152a6
TK
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
8523533c 660 eximsrs_done();
384152a6
TK
661
662 if(n_srs != OK)
663 return n_srs;
8523533c 664 }
384152a6 665 }
8523533c
TK
666 }
667#endif
668
0756eb3c
PH
669/* Call the function that interprets redirection data, either inline or from a
670file. This is a separate function so that the system filter can use it. It will
671run the function in a subprocess if necessary. If qualify_preserve_domain is
672set, temporarily reset qualify_domain_recipient to the current domain so that
673any unqualified addresses get qualified with the same domain as the incoming
674address. Otherwise, if a local qualify_domain is provided, set that up. */
675
676if (ob->qualify_preserve_domain)
677 qualify_domain_recipient = addr->domain;
f3ebb786 678else if (ob->qualify_domain)
0756eb3c
PH
679 {
680 uschar *new_qdr = rf_expand_data(addr, ob->qualify_domain, &xrc);
f3ebb786 681 if (!new_qdr) return xrc;
0756eb3c
PH
682 qualify_domain_recipient = new_qdr;
683 }
684
685redirect.owners = ob->owners;
686redirect.owngroups = ob->owngroups;
687redirect.modemask = ob->modemask;
688redirect.check_owner = ob->check_owner;
689redirect.check_group = ob->check_group;
690redirect.pw = pw;
691
f3ebb786
JH
692redirect.string = (redirect.isfile = (ob->file != NULL))
693 ? ob->file : ob->data;
0756eb3c
PH
694
695frc = rda_interpret(&redirect, options, ob->include_directory,
efd9a422
MH
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));
0756eb3c
PH
700
701qualify_domain_recipient = save_qualify_domain_recipient;
702
703/* Handle exceptional returns from filtering or processing an address list.
704For FAIL and FREEZE we honour any previously set up deliveries by a filter. */
705
706switch (frc)
707 {
708 case FF_NONEXIST:
f3ebb786
JH
709 addr->message = addr->user_message = NULL;
710 return DECLINE;
0756eb3c
PH
711
712 case FF_BLACKHOLE:
f3ebb786
JH
713 DEBUG(D_route) debug_printf("address :blackhole:d\n");
714 generated = NULL;
715 discarded = US":blackhole:";
716 frc = FF_DELIVERED;
717 break;
0756eb3c 718
f3ebb786
JH
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. */
0756eb3c
PH
723
724 case FF_DEFER:
f3ebb786
JH
725 yield = DEFER;
726 goto SORT_MESSAGE;
0756eb3c
PH
727
728 case FF_FAIL:
f3ebb786
JH
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
a5bd321b 738 {
f3ebb786
JH
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);
a5bd321b 751 }
f3ebb786 752 return yield;
0756eb3c 753
f3ebb786
JH
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. */
0756eb3c
PH
757
758 case FF_FREEZE:
f3ebb786
JH
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;
0756eb3c 771
f3ebb786 772 /* Handle syntax errors and :include: failures and lookup defers */
0756eb3c
PH
773
774 case FF_ERROR:
775 case FF_INCLUDEFAIL:
776
f3ebb786
JH
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. */
0756eb3c 781
f3ebb786 782 if (filtertype == FILTER_UNSET) return DEFER;
0756eb3c 783
f3ebb786
JH
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. */
0756eb3c 786
f3ebb786
JH
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 }
0756eb3c 795
f3ebb786 796 /* Otherwise set up the error for the address and defer. */
0756eb3c 797
f3ebb786
JH
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 }
0756eb3c
PH
807 }
808
809
810/* Yield is either FF_DELIVERED (significant action) or FF_NOTDELIVERED (no
811significant action). Before dealing with these, however, we must handle the
812effect of skip_syntax_errors.
813
814If skip_syntax_errors was set and there were syntax errors in an address list,
815error messages will be present in eblock. Log them and send a message if so
816configured. We cannot do this earlier, because the error message must not be
817sent as the local user. If there were no valid addresses, generated will be
818NULL. In this case, the router declines.
819
820For a filter file, the error message has been fudged into an eblock. After
821dealing with it, the router declines. */
822
823if (eblock != NULL)
824 {
825 if (!moan_skipped_syntax_errors(
fd6de02e
PH
826 rblock->name, /* For message content */
827 eblock, /* Ditto */
8768d548 828 (verify != v_none || f.address_test_mode)?
fd6de02e
PH
829 NULL : ob->syntax_errors_to, /* Who to mail */
830 generated != NULL, /* True if not all failed */
831 ob->syntax_errors_text)) /* Custom message */
0756eb3c
PH
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
842generated addresses, if any. If there are no generated addresses, we must avoid
843calling sort_errors_and_headers() in case this router declines - that function
844may modify the errors_address field in the current address, and we don't want
845to do that for a decline. */
846
847if (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
855contains :blackhole: or a filter contains "seen finish" without having
856generated anything. Log what happened to this address, and return DISCARD. */
857
858if (frc == FF_DELIVERED)
859 {
8768d548 860 if (generated == NULL && verify == v_none && !f.address_test_mode)
0756eb3c
PH
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
869generated. For a filter, addresses may or may not have been generated. If none
870were, it's the same as an empty address list, and the router declines. However,
871if addresses were generated, we can't just decline because successful delivery
872of the base address gets it marked "done", so deferred generated addresses
873never get tried again. We have to generate a new version of the base address,
874as if there were a "deliver" command in the filter file, with the original
875address as parent. */
876
877else
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
7eb0e5d2 889 /* Set the data that propagates. */
0756eb3c 890
d43cbe25 891 next->prop = addr_prop;
0756eb3c
PH
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
902original address onto the succeed queue so that any retry items that get
903attached to it get processed. */
904
905addr->next = *addr_succeed;
906*addr_succeed = addr;
907
908return yield;
909}
910
d185889f 911#endif /*!MACRO_PREDEF*/
0756eb3c 912/* End of routers/redirect.c */