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