Put a note in the WishList file that it is now obsolete and that
[exim.git] / src / src / acl.c
CommitLineData
c3611384 1/* $Cambridge: exim/src/src/acl.c,v 1.74 2007/02/14 15:33:40 ph10 Exp $ */
059ec3d9
PH
2
3/*************************************************
4* Exim - an Internet mail transport agent *
5*************************************************/
6
184e8823 7/* Copyright (c) University of Cambridge 1995 - 2007 */
059ec3d9
PH
8/* See the file NOTICE for conditions of use and distribution. */
9
10/* Code for handling Access Control Lists (ACLs) */
11
12#include "exim.h"
13
14
15/* Default callout timeout */
16
17#define CALLOUT_TIMEOUT_DEFAULT 30
18
19/* ACL verb codes - keep in step with the table of verbs that follows */
20
21enum { ACL_ACCEPT, ACL_DEFER, ACL_DENY, ACL_DISCARD, ACL_DROP, ACL_REQUIRE,
22 ACL_WARN };
23
24/* ACL verbs */
25
26static uschar *verbs[] =
27 { US"accept", US"defer", US"deny", US"discard", US"drop", US"require",
28 US"warn" };
29
4e88a19f
PH
30/* For each verb, the conditions for which "message" or "log_message" are used
31are held as a bitmap. This is to avoid expanding the strings unnecessarily. For
32"accept", the FAIL case is used only after "endpass", but that is selected in
33the code. */
34
35static int msgcond[] = {
36 (1<<OK) | (1<<FAIL) | (1<<FAIL_DROP), /* accept */
37 (1<<OK), /* defer */
38 (1<<OK), /* deny */
39 (1<<OK) | (1<<FAIL) | (1<<FAIL_DROP), /* discard */
40 (1<<OK), /* drop */
41 (1<<FAIL) | (1<<FAIL_DROP), /* require */
42 (1<<OK) /* warn */
43 };
059ec3d9
PH
44
45/* ACL condition and modifier codes - keep in step with the table that
71fafd95
PH
46follows, and the cond_expand_at_top and uschar cond_modifiers tables lower
47down. */
059ec3d9 48
71fafd95
PH
49enum { ACLC_ACL,
50 ACLC_ADD_HEADER,
51 ACLC_AUTHENTICATED,
8523533c
TK
52#ifdef EXPERIMENTAL_BRIGHTMAIL
53 ACLC_BMI_OPTIN,
54#endif
71fafd95 55 ACLC_CONDITION,
c3611384 56 ACLC_CONTINUE,
71fafd95 57 ACLC_CONTROL,
8523533c
TK
58#ifdef WITH_CONTENT_SCAN
59 ACLC_DECODE,
60#endif
61 ACLC_DELAY,
62#ifdef WITH_OLD_DEMIME
63 ACLC_DEMIME,
fb2274d4
TK
64#endif
65#ifdef EXPERIMENTAL_DOMAINKEYS
66 ACLC_DK_DOMAIN_SOURCE,
67 ACLC_DK_POLICY,
68 ACLC_DK_SENDER_DOMAINS,
69 ACLC_DK_SENDER_LOCAL_PARTS,
70 ACLC_DK_SENDERS,
71 ACLC_DK_STATUS,
8e669ac1 72#endif
71fafd95
PH
73 ACLC_DNSLISTS,
74 ACLC_DOMAINS,
75 ACLC_ENCRYPTED,
76 ACLC_ENDPASS,
77 ACLC_HOSTS,
78 ACLC_LOCAL_PARTS,
79 ACLC_LOG_MESSAGE,
6ea85e9a 80 ACLC_LOG_REJECT_TARGET,
71fafd95 81 ACLC_LOGWRITE,
8523533c
TK
82#ifdef WITH_CONTENT_SCAN
83 ACLC_MALWARE,
84#endif
85 ACLC_MESSAGE,
86#ifdef WITH_CONTENT_SCAN
87 ACLC_MIME_REGEX,
88#endif
870f6ba8 89 ACLC_RATELIMIT,
8523533c
TK
90 ACLC_RECIPIENTS,
91#ifdef WITH_CONTENT_SCAN
92 ACLC_REGEX,
93#endif
71fafd95
PH
94 ACLC_SENDER_DOMAINS,
95 ACLC_SENDERS,
96 ACLC_SET,
8523533c 97#ifdef WITH_CONTENT_SCAN
8e669ac1 98 ACLC_SPAM,
8523533c
TK
99#endif
100#ifdef EXPERIMENTAL_SPF
101 ACLC_SPF,
102#endif
103 ACLC_VERIFY };
059ec3d9 104
c3611384
PH
105/* ACL conditions/modifiers: "delay", "control", "continue", "endpass",
106"message", "log_message", "log_reject_target", "logwrite", and "set" are
107modifiers that look like conditions but always return TRUE. They are used for
108their side effects. */
059ec3d9 109
9a26b6b2
PH
110static uschar *conditions[] = {
111 US"acl",
71fafd95 112 US"add_header",
9a26b6b2 113 US"authenticated",
8523533c
TK
114#ifdef EXPERIMENTAL_BRIGHTMAIL
115 US"bmi_optin",
116#endif
117 US"condition",
c3611384 118 US"continue",
8e669ac1 119 US"control",
8523533c
TK
120#ifdef WITH_CONTENT_SCAN
121 US"decode",
122#endif
123 US"delay",
124#ifdef WITH_OLD_DEMIME
125 US"demime",
fb2274d4
TK
126#endif
127#ifdef EXPERIMENTAL_DOMAINKEYS
7f45268c
PH
128 US"dk_domain_source",
129 US"dk_policy",
130 US"dk_sender_domains",
131 US"dk_sender_local_parts",
132 US"dk_senders",
133 US"dk_status",
8523533c 134#endif
6ea85e9a
PH
135 US"dnslists",
136 US"domains",
137 US"encrypted",
138 US"endpass",
139 US"hosts",
140 US"local_parts",
141 US"log_message",
142 US"log_reject_target",
143 US"logwrite",
8523533c
TK
144#ifdef WITH_CONTENT_SCAN
145 US"malware",
146#endif
147 US"message",
148#ifdef WITH_CONTENT_SCAN
149 US"mime_regex",
150#endif
870f6ba8 151 US"ratelimit",
8523533c
TK
152 US"recipients",
153#ifdef WITH_CONTENT_SCAN
154 US"regex",
155#endif
156 US"sender_domains", US"senders", US"set",
157#ifdef WITH_CONTENT_SCAN
158 US"spam",
159#endif
160#ifdef EXPERIMENTAL_SPF
161 US"spf",
162#endif
059ec3d9 163 US"verify" };
8e669ac1 164
c5fcb476 165
9a26b6b2
PH
166/* Return values from decode_control(); keep in step with the table of names
167that follows! */
168
169enum {
c46782ef
PH
170 CONTROL_AUTH_UNADVERTISED,
171 #ifdef EXPERIMENTAL_BRIGHTMAIL
9a26b6b2 172 CONTROL_BMI_RUN,
c46782ef
PH
173 #endif
174 #ifdef EXPERIMENTAL_DOMAINKEYS
9a26b6b2 175 CONTROL_DK_VERIFY,
c46782ef
PH
176 #endif
177 CONTROL_ERROR,
178 CONTROL_CASEFUL_LOCAL_PART,
179 CONTROL_CASELOWER_LOCAL_PART,
180 CONTROL_ENFORCE_SYNC,
181 CONTROL_NO_ENFORCE_SYNC,
182 CONTROL_FREEZE,
183 CONTROL_QUEUE_ONLY,
184 CONTROL_SUBMISSION,
185 CONTROL_SUPPRESS_LOCAL_FIXUPS,
186 #ifdef WITH_CONTENT_SCAN
9a26b6b2 187 CONTROL_NO_MBOX_UNSPOOL,
c46782ef
PH
188 #endif
189 CONTROL_FAKEDEFER,
190 CONTROL_FAKEREJECT,
cf8b11a5 191 CONTROL_NO_MULTILINE,
047bdd8c 192 CONTROL_NO_PIPELINING,
4c590bd1
PH
193 CONTROL_NO_DELAY_FLUSH,
194 CONTROL_NO_CALLOUT_FLUSH
c46782ef 195};
9a26b6b2 196
8800895a
PH
197/* ACL control names; keep in step with the table above! This list is used for
198turning ids into names. The actual list of recognized names is in the variable
199control_def controls_list[] below. The fact that there are two lists is a mess
200and should be tidied up. */
9a26b6b2
PH
201
202static uschar *controls[] = {
c46782ef 203 US"allow_auth_unadvertised",
9a26b6b2
PH
204 #ifdef EXPERIMENTAL_BRIGHTMAIL
205 US"bmi_run",
206 #endif
207 #ifdef EXPERIMENTAL_DOMAINKEYS
208 US"dk_verify",
209 #endif
c46782ef
PH
210 US"error",
211 US"caseful_local_part",
212 US"caselower_local_part",
213 US"enforce_sync",
214 US"no_enforce_sync",
215 US"freeze",
216 US"queue_only",
217 US"submission",
218 US"suppress_local_fixups",
9a26b6b2
PH
219 #ifdef WITH_CONTENT_SCAN
220 US"no_mbox_unspool",
221 #endif
cf8b11a5
PH
222 US"fakedefer",
223 US"fakereject",
224 US"no_multiline",
225 US"no_pipelining",
4c590bd1
PH
226 US"no_delay_flush",
227 US"no_callout_flush"
c46782ef 228};
059ec3d9 229
047bdd8c 230/* Flags to indicate for which conditions/modifiers a string expansion is done
059ec3d9
PH
231at the outer level. In the other cases, expansion already occurs in the
232checking functions. */
233
234static uschar cond_expand_at_top[] = {
235 TRUE, /* acl */
3e536984 236 TRUE, /* add_header */
059ec3d9 237 FALSE, /* authenticated */
8523533c
TK
238#ifdef EXPERIMENTAL_BRIGHTMAIL
239 TRUE, /* bmi_optin */
8e669ac1 240#endif
059ec3d9 241 TRUE, /* condition */
c3611384 242 TRUE, /* continue */
059ec3d9 243 TRUE, /* control */
8523533c
TK
244#ifdef WITH_CONTENT_SCAN
245 TRUE, /* decode */
246#endif
059ec3d9 247 TRUE, /* delay */
8523533c
TK
248#ifdef WITH_OLD_DEMIME
249 TRUE, /* demime */
fb2274d4
TK
250#endif
251#ifdef EXPERIMENTAL_DOMAINKEYS
7f45268c
PH
252 TRUE, /* dk_domain_source */
253 TRUE, /* dk_policy */
254 TRUE, /* dk_sender_domains */
e715ad22 255 TRUE, /* dk_sender_local_parts */
7f45268c
PH
256 TRUE, /* dk_senders */
257 TRUE, /* dk_status */
8523533c 258#endif
059ec3d9
PH
259 TRUE, /* dnslists */
260 FALSE, /* domains */
261 FALSE, /* encrypted */
262 TRUE, /* endpass */
263 FALSE, /* hosts */
264 FALSE, /* local_parts */
265 TRUE, /* log_message */
6ea85e9a 266 TRUE, /* log_reject_target */
059ec3d9 267 TRUE, /* logwrite */
8523533c
TK
268#ifdef WITH_CONTENT_SCAN
269 TRUE, /* malware */
270#endif
059ec3d9 271 TRUE, /* message */
8523533c
TK
272#ifdef WITH_CONTENT_SCAN
273 TRUE, /* mime_regex */
274#endif
870f6ba8 275 TRUE, /* ratelimit */
059ec3d9 276 FALSE, /* recipients */
8523533c
TK
277#ifdef WITH_CONTENT_SCAN
278 TRUE, /* regex */
279#endif
059ec3d9
PH
280 FALSE, /* sender_domains */
281 FALSE, /* senders */
282 TRUE, /* set */
8523533c
TK
283#ifdef WITH_CONTENT_SCAN
284 TRUE, /* spam */
285#endif
286#ifdef EXPERIMENTAL_SPF
287 TRUE, /* spf */
288#endif
059ec3d9
PH
289 TRUE /* verify */
290};
291
292/* Flags to identify the modifiers */
293
294static uschar cond_modifiers[] = {
295 FALSE, /* acl */
3e536984 296 TRUE, /* add_header */
059ec3d9 297 FALSE, /* authenticated */
8523533c
TK
298#ifdef EXPERIMENTAL_BRIGHTMAIL
299 TRUE, /* bmi_optin */
8e669ac1 300#endif
059ec3d9 301 FALSE, /* condition */
c3611384 302 TRUE, /* continue */
059ec3d9 303 TRUE, /* control */
8523533c
TK
304#ifdef WITH_CONTENT_SCAN
305 FALSE, /* decode */
306#endif
059ec3d9 307 TRUE, /* delay */
8523533c
TK
308#ifdef WITH_OLD_DEMIME
309 FALSE, /* demime */
fb2274d4
TK
310#endif
311#ifdef EXPERIMENTAL_DOMAINKEYS
7f45268c
PH
312 FALSE, /* dk_domain_source */
313 FALSE, /* dk_policy */
314 FALSE, /* dk_sender_domains */
e715ad22 315 FALSE, /* dk_sender_local_parts */
7f45268c
PH
316 FALSE, /* dk_senders */
317 FALSE, /* dk_status */
8523533c 318#endif
059ec3d9
PH
319 FALSE, /* dnslists */
320 FALSE, /* domains */
321 FALSE, /* encrypted */
322 TRUE, /* endpass */
323 FALSE, /* hosts */
324 FALSE, /* local_parts */
325 TRUE, /* log_message */
6ea85e9a 326 TRUE, /* log_reject_target */
8523533c
TK
327 TRUE, /* logwrite */
328#ifdef WITH_CONTENT_SCAN
329 FALSE, /* malware */
330#endif
059ec3d9 331 TRUE, /* message */
8523533c
TK
332#ifdef WITH_CONTENT_SCAN
333 FALSE, /* mime_regex */
334#endif
870f6ba8 335 FALSE, /* ratelimit */
059ec3d9 336 FALSE, /* recipients */
8523533c
TK
337#ifdef WITH_CONTENT_SCAN
338 FALSE, /* regex */
339#endif
059ec3d9
PH
340 FALSE, /* sender_domains */
341 FALSE, /* senders */
342 TRUE, /* set */
8523533c
TK
343#ifdef WITH_CONTENT_SCAN
344 FALSE, /* spam */
345#endif
346#ifdef EXPERIMENTAL_SPF
347 FALSE, /* spf */
348#endif
059ec3d9
PH
349 FALSE /* verify */
350};
351
c3611384
PH
352/* Bit map vector of which conditions and modifiers are not allowed at certain
353times. For each condition, there's a bitmap of dis-allowed times. For some, it
354is easier to specify the negation of a small number of allowed times. */
059ec3d9
PH
355
356static unsigned int cond_forbids[] = {
357 0, /* acl */
8e669ac1 358
71fafd95 359 (unsigned int)
45b91596 360 ~((1<<ACL_WHERE_MAIL)|(1<<ACL_WHERE_RCPT)| /* add_header */
71fafd95 361 (1<<ACL_WHERE_PREDATA)|(1<<ACL_WHERE_DATA)|
45b91596
PH
362 (1<<ACL_WHERE_MIME)|(1<<ACL_WHERE_NOTSMTP)|
363 (1<<ACL_WHERE_NOTSMTP_START)),
71fafd95 364
45b91596
PH
365 (1<<ACL_WHERE_NOTSMTP)| /* authenticated */
366 (1<<ACL_WHERE_NOTSMTP_START)|
367 (1<<ACL_WHERE_CONNECT)|(1<<ACL_WHERE_HELO),
8e669ac1 368
71fafd95 369 #ifdef EXPERIMENTAL_BRIGHTMAIL
3864bb8e 370 (1<<ACL_WHERE_AUTH)| /* bmi_optin */
8523533c
TK
371 (1<<ACL_WHERE_CONNECT)|(1<<ACL_WHERE_HELO)|
372 (1<<ACL_WHERE_DATA)|(1<<ACL_WHERE_MIME)|
8e669ac1 373 (1<<ACL_WHERE_ETRN)|(1<<ACL_WHERE_EXPN)|
8523533c
TK
374 (1<<ACL_WHERE_MAILAUTH)|
375 (1<<ACL_WHERE_MAIL)|(1<<ACL_WHERE_STARTTLS)|
45b91596
PH
376 (1<<ACL_WHERE_VRFY)|(1<<ACL_WHERE_PREDATA)|
377 (1<<ACL_WHERE_NOTSMTP_START),
71fafd95 378 #endif
8e669ac1 379
059ec3d9 380 0, /* condition */
8e669ac1 381
c3611384
PH
382 0, /* continue */
383
059ec3d9 384 /* Certain types of control are always allowed, so we let it through
2f079f46 385 always and check in the control processing itself. */
8e669ac1 386
059ec3d9 387 0, /* control */
8e669ac1 388
71fafd95 389 #ifdef WITH_CONTENT_SCAN
2f079f46
PH
390 (unsigned int)
391 ~(1<<ACL_WHERE_MIME), /* decode */
71fafd95 392 #endif
8523533c 393
059ec3d9 394 0, /* delay */
8e669ac1 395
71fafd95 396 #ifdef WITH_OLD_DEMIME
2f079f46
PH
397 (unsigned int)
398 ~((1<<ACL_WHERE_DATA)|(1<<ACL_WHERE_NOTSMTP)), /* demime */
71fafd95 399 #endif
8e669ac1 400
71fafd95 401 #ifdef EXPERIMENTAL_DOMAINKEYS
2f079f46 402 (1<<ACL_WHERE_AUTH)| /* dk_domain_source */
fb2274d4
TK
403 (1<<ACL_WHERE_CONNECT)|(1<<ACL_WHERE_HELO)|
404 (1<<ACL_WHERE_RCPT)|(1<<ACL_WHERE_PREDATA)|
405 (1<<ACL_WHERE_ETRN)|(1<<ACL_WHERE_EXPN)|
406 (1<<ACL_WHERE_MAILAUTH)|(1<<ACL_WHERE_QUIT)|
407 (1<<ACL_WHERE_MAIL)|(1<<ACL_WHERE_STARTTLS)|
45b91596 408 (1<<ACL_WHERE_VRFY)|(1<<ACL_WHERE_NOTSMTP_START),
84330b7b 409
2f079f46 410 (1<<ACL_WHERE_AUTH)| /* dk_policy */
fb2274d4
TK
411 (1<<ACL_WHERE_CONNECT)|(1<<ACL_WHERE_HELO)|
412 (1<<ACL_WHERE_RCPT)|(1<<ACL_WHERE_PREDATA)|
413 (1<<ACL_WHERE_ETRN)|(1<<ACL_WHERE_EXPN)|
414 (1<<ACL_WHERE_MAILAUTH)|(1<<ACL_WHERE_QUIT)|
415 (1<<ACL_WHERE_MAIL)|(1<<ACL_WHERE_STARTTLS)|
45b91596 416 (1<<ACL_WHERE_VRFY)|(1<<ACL_WHERE_NOTSMTP_START),
84330b7b 417
2f079f46 418 (1<<ACL_WHERE_AUTH)| /* dk_sender_domains */
fb2274d4
TK
419 (1<<ACL_WHERE_CONNECT)|(1<<ACL_WHERE_HELO)|
420 (1<<ACL_WHERE_RCPT)|(1<<ACL_WHERE_PREDATA)|
421 (1<<ACL_WHERE_ETRN)|(1<<ACL_WHERE_EXPN)|
422 (1<<ACL_WHERE_MAILAUTH)|(1<<ACL_WHERE_QUIT)|
423 (1<<ACL_WHERE_MAIL)|(1<<ACL_WHERE_STARTTLS)|
45b91596 424 (1<<ACL_WHERE_VRFY)|(1<<ACL_WHERE_NOTSMTP_START),
84330b7b 425
2f079f46 426 (1<<ACL_WHERE_AUTH)| /* dk_sender_local_parts */
fb2274d4
TK
427 (1<<ACL_WHERE_CONNECT)|(1<<ACL_WHERE_HELO)|
428 (1<<ACL_WHERE_RCPT)|(1<<ACL_WHERE_PREDATA)|
429 (1<<ACL_WHERE_ETRN)|(1<<ACL_WHERE_EXPN)|
430 (1<<ACL_WHERE_MAILAUTH)|(1<<ACL_WHERE_QUIT)|
431 (1<<ACL_WHERE_MAIL)|(1<<ACL_WHERE_STARTTLS)|
45b91596 432 (1<<ACL_WHERE_VRFY)|(1<<ACL_WHERE_NOTSMTP_START),
84330b7b 433
2f079f46 434 (1<<ACL_WHERE_AUTH)| /* dk_senders */
fb2274d4
TK
435 (1<<ACL_WHERE_CONNECT)|(1<<ACL_WHERE_HELO)|
436 (1<<ACL_WHERE_RCPT)|(1<<ACL_WHERE_PREDATA)|
437 (1<<ACL_WHERE_ETRN)|(1<<ACL_WHERE_EXPN)|
438 (1<<ACL_WHERE_MAILAUTH)|(1<<ACL_WHERE_QUIT)|
439 (1<<ACL_WHERE_MAIL)|(1<<ACL_WHERE_STARTTLS)|
45b91596 440 (1<<ACL_WHERE_VRFY)|(1<<ACL_WHERE_NOTSMTP_START),
84330b7b 441
2f079f46 442 (1<<ACL_WHERE_AUTH)| /* dk_status */
fb2274d4
TK
443 (1<<ACL_WHERE_CONNECT)|(1<<ACL_WHERE_HELO)|
444 (1<<ACL_WHERE_RCPT)|(1<<ACL_WHERE_PREDATA)|
445 (1<<ACL_WHERE_ETRN)|(1<<ACL_WHERE_EXPN)|
446 (1<<ACL_WHERE_MAILAUTH)|(1<<ACL_WHERE_QUIT)|
447 (1<<ACL_WHERE_MAIL)|(1<<ACL_WHERE_STARTTLS)|
45b91596 448 (1<<ACL_WHERE_VRFY)|(1<<ACL_WHERE_NOTSMTP_START),
71fafd95 449 #endif
fb2274d4 450
45b91596
PH
451 (1<<ACL_WHERE_NOTSMTP)| /* dnslists */
452 (1<<ACL_WHERE_NOTSMTP_START),
059ec3d9 453
2f079f46
PH
454 (unsigned int)
455 ~(1<<ACL_WHERE_RCPT), /* domains */
059ec3d9 456
45b91596
PH
457 (1<<ACL_WHERE_NOTSMTP)| /* encrypted */
458 (1<<ACL_WHERE_CONNECT)|
459 (1<<ACL_WHERE_NOTSMTP_START)|
059ec3d9 460 (1<<ACL_WHERE_HELO),
8e669ac1 461
059ec3d9 462 0, /* endpass */
8e669ac1 463
45b91596
PH
464 (1<<ACL_WHERE_NOTSMTP)| /* hosts */
465 (1<<ACL_WHERE_NOTSMTP_START),
059ec3d9 466
2f079f46
PH
467 (unsigned int)
468 ~(1<<ACL_WHERE_RCPT), /* local_parts */
059ec3d9
PH
469
470 0, /* log_message */
8e669ac1 471
6ea85e9a
PH
472 0, /* log_reject_target */
473
059ec3d9 474 0, /* logwrite */
8e669ac1 475
71fafd95 476 #ifdef WITH_CONTENT_SCAN
2f079f46
PH
477 (unsigned int)
478 ~((1<<ACL_WHERE_DATA)|(1<<ACL_WHERE_NOTSMTP)), /* malware */
71fafd95 479 #endif
8523533c 480
059ec3d9
PH
481 0, /* message */
482
71fafd95 483 #ifdef WITH_CONTENT_SCAN
2f079f46
PH
484 (unsigned int)
485 ~(1<<ACL_WHERE_MIME), /* mime_regex */
71fafd95 486 #endif
8523533c 487
870f6ba8
TF
488 0, /* ratelimit */
489
2f079f46
PH
490 (unsigned int)
491 ~(1<<ACL_WHERE_RCPT), /* recipients */
059ec3d9 492
71fafd95 493 #ifdef WITH_CONTENT_SCAN
2f079f46
PH
494 (unsigned int)
495 ~((1<<ACL_WHERE_DATA)|(1<<ACL_WHERE_NOTSMTP)| /* regex */
496 (1<<ACL_WHERE_MIME)),
71fafd95 497 #endif
8523533c 498
059ec3d9
PH
499 (1<<ACL_WHERE_AUTH)|(1<<ACL_WHERE_CONNECT)| /* sender_domains */
500 (1<<ACL_WHERE_HELO)|
501 (1<<ACL_WHERE_MAILAUTH)|(1<<ACL_WHERE_QUIT)|
502 (1<<ACL_WHERE_ETRN)|(1<<ACL_WHERE_EXPN)|
503 (1<<ACL_WHERE_STARTTLS)|(1<<ACL_WHERE_VRFY),
504
505 (1<<ACL_WHERE_AUTH)|(1<<ACL_WHERE_CONNECT)| /* senders */
506 (1<<ACL_WHERE_HELO)|
507 (1<<ACL_WHERE_MAILAUTH)|(1<<ACL_WHERE_QUIT)|
508 (1<<ACL_WHERE_ETRN)|(1<<ACL_WHERE_EXPN)|
509 (1<<ACL_WHERE_STARTTLS)|(1<<ACL_WHERE_VRFY),
510
511 0, /* set */
512
71fafd95 513 #ifdef WITH_CONTENT_SCAN
2f079f46
PH
514 (unsigned int)
515 ~((1<<ACL_WHERE_DATA)|(1<<ACL_WHERE_NOTSMTP)), /* spam */
71fafd95 516 #endif
8523533c 517
71fafd95 518 #ifdef EXPERIMENTAL_SPF
8523533c
TK
519 (1<<ACL_WHERE_AUTH)|(1<<ACL_WHERE_CONNECT)| /* spf */
520 (1<<ACL_WHERE_HELO)|
521 (1<<ACL_WHERE_MAILAUTH)|
522 (1<<ACL_WHERE_ETRN)|(1<<ACL_WHERE_EXPN)|
45b91596
PH
523 (1<<ACL_WHERE_STARTTLS)|(1<<ACL_WHERE_VRFY)|
524 (1<<ACL_WHERE_NOTSMTP)|
525 (1<<ACL_WHERE_NOTSMTP_START),
71fafd95 526 #endif
8523533c 527
059ec3d9
PH
528 /* Certain types of verify are always allowed, so we let it through
529 always and check in the verify function itself */
530
531 0 /* verify */
059ec3d9
PH
532};
533
534
c5fcb476
PH
535/* Bit map vector of which controls are not allowed at certain times. For
536each control, there's a bitmap of dis-allowed times. For some, it is easier to
537specify the negation of a small number of allowed times. */
538
539static unsigned int control_forbids[] = {
c46782ef
PH
540 (unsigned int)
541 ~((1<<ACL_WHERE_CONNECT)|(1<<ACL_WHERE_HELO)), /* allow_auth_unadvertised */
542
543 #ifdef EXPERIMENTAL_BRIGHTMAIL
8523533c 544 0, /* bmi_run */
c46782ef
PH
545 #endif
546
547 #ifdef EXPERIMENTAL_DOMAINKEYS
45b91596
PH
548 (1<<ACL_WHERE_DATA)|(1<<ACL_WHERE_NOTSMTP)| /* dk_verify */
549 (1<<ACL_WHERE_NOTSMTP_START),
c46782ef 550 #endif
3e11c26b 551
c5fcb476 552 0, /* error */
8e669ac1
PH
553
554 (unsigned int)
c5fcb476 555 ~(1<<ACL_WHERE_RCPT), /* caseful_local_part */
8e669ac1
PH
556
557 (unsigned int)
c5fcb476 558 ~(1<<ACL_WHERE_RCPT), /* caselower_local_part */
8e669ac1 559
45b91596
PH
560 (1<<ACL_WHERE_NOTSMTP)| /* enforce_sync */
561 (1<<ACL_WHERE_NOTSMTP_START),
8e669ac1 562
45b91596
PH
563 (1<<ACL_WHERE_NOTSMTP)| /* no_enforce_sync */
564 (1<<ACL_WHERE_NOTSMTP_START),
8e669ac1
PH
565
566 (unsigned int)
c5fcb476
PH
567 ~((1<<ACL_WHERE_MAIL)|(1<<ACL_WHERE_RCPT)| /* freeze */
568 (1<<ACL_WHERE_PREDATA)|(1<<ACL_WHERE_DATA)|
e715ad22 569 (1<<ACL_WHERE_NOTSMTP)|(1<<ACL_WHERE_MIME)),
8e669ac1
PH
570
571 (unsigned int)
c5fcb476
PH
572 ~((1<<ACL_WHERE_MAIL)|(1<<ACL_WHERE_RCPT)| /* queue_only */
573 (1<<ACL_WHERE_PREDATA)|(1<<ACL_WHERE_DATA)|
e715ad22 574 (1<<ACL_WHERE_NOTSMTP)|(1<<ACL_WHERE_MIME)),
8e669ac1
PH
575
576 (unsigned int)
c5fcb476 577 ~((1<<ACL_WHERE_MAIL)|(1<<ACL_WHERE_RCPT)| /* submission */
8e669ac1 578 (1<<ACL_WHERE_PREDATA)),
8523533c 579
8800895a
PH
580 (unsigned int)
581 ~((1<<ACL_WHERE_MAIL)|(1<<ACL_WHERE_RCPT)| /* suppress_local_fixups */
45b91596
PH
582 (1<<ACL_WHERE_PREDATA)|
583 (1<<ACL_WHERE_NOTSMTP_START)),
8800895a 584
c46782ef 585 #ifdef WITH_CONTENT_SCAN
8e669ac1 586 (unsigned int)
14d57970 587 ~((1<<ACL_WHERE_MAIL)|(1<<ACL_WHERE_RCPT)| /* no_mbox_unspool */
e715ad22
TK
588 (1<<ACL_WHERE_PREDATA)|(1<<ACL_WHERE_DATA)|
589 (1<<ACL_WHERE_MIME)),
c46782ef 590 #endif
a6c4ab60 591
29aba418
TF
592 (unsigned int)
593 ~((1<<ACL_WHERE_MAIL)|(1<<ACL_WHERE_RCPT)| /* fakedefer */
594 (1<<ACL_WHERE_PREDATA)|(1<<ACL_WHERE_DATA)|
595 (1<<ACL_WHERE_MIME)),
596
8e669ac1 597 (unsigned int)
a6c4ab60 598 ~((1<<ACL_WHERE_MAIL)|(1<<ACL_WHERE_RCPT)| /* fakereject */
e715ad22
TK
599 (1<<ACL_WHERE_PREDATA)|(1<<ACL_WHERE_DATA)|
600 (1<<ACL_WHERE_MIME)),
8523533c 601
45b91596 602 (1<<ACL_WHERE_NOTSMTP)| /* no_multiline */
cf8b11a5
PH
603 (1<<ACL_WHERE_NOTSMTP_START),
604
605 (1<<ACL_WHERE_NOTSMTP)| /* no_pipelining */
047bdd8c
PH
606 (1<<ACL_WHERE_NOTSMTP_START),
607
608 (1<<ACL_WHERE_NOTSMTP)| /* no_delay_flush */
4c590bd1
PH
609 (1<<ACL_WHERE_NOTSMTP_START),
610
611 (1<<ACL_WHERE_NOTSMTP)| /* no_callout_flush */
45b91596 612 (1<<ACL_WHERE_NOTSMTP_START)
c5fcb476
PH
613};
614
615/* Structure listing various control arguments, with their characteristics. */
059ec3d9
PH
616
617typedef struct control_def {
618 uschar *name;
619 int value; /* CONTROL_xxx value */
059ec3d9
PH
620 BOOL has_option; /* Has /option(s) following */
621} control_def;
622
623static control_def controls_list[] = {
c46782ef 624 { US"allow_auth_unadvertised", CONTROL_AUTH_UNADVERTISED, FALSE },
8523533c 625#ifdef EXPERIMENTAL_BRIGHTMAIL
c46782ef 626 { US"bmi_run", CONTROL_BMI_RUN, FALSE },
fb2274d4
TK
627#endif
628#ifdef EXPERIMENTAL_DOMAINKEYS
c46782ef 629 { US"dk_verify", CONTROL_DK_VERIFY, FALSE },
8523533c 630#endif
c46782ef
PH
631 { US"caseful_local_part", CONTROL_CASEFUL_LOCAL_PART, FALSE },
632 { US"caselower_local_part", CONTROL_CASELOWER_LOCAL_PART, FALSE },
633 { US"enforce_sync", CONTROL_ENFORCE_SYNC, FALSE },
634 { US"freeze", CONTROL_FREEZE, TRUE },
4c590bd1 635 { US"no_callout_flush", CONTROL_NO_CALLOUT_FLUSH, FALSE },
047bdd8c 636 { US"no_delay_flush", CONTROL_NO_DELAY_FLUSH, FALSE },
c46782ef
PH
637 { US"no_enforce_sync", CONTROL_NO_ENFORCE_SYNC, FALSE },
638 { US"no_multiline_responses", CONTROL_NO_MULTILINE, FALSE },
cf8b11a5 639 { US"no_pipelining", CONTROL_NO_PIPELINING, FALSE },
c46782ef 640 { US"queue_only", CONTROL_QUEUE_ONLY, FALSE },
8523533c 641#ifdef WITH_CONTENT_SCAN
c46782ef 642 { US"no_mbox_unspool", CONTROL_NO_MBOX_UNSPOOL, FALSE },
8523533c 643#endif
c46782ef
PH
644 { US"fakedefer", CONTROL_FAKEDEFER, TRUE },
645 { US"fakereject", CONTROL_FAKEREJECT, TRUE },
646 { US"submission", CONTROL_SUBMISSION, TRUE },
647 { US"suppress_local_fixups", CONTROL_SUPPRESS_LOCAL_FIXUPS, FALSE }
059ec3d9
PH
648 };
649
e5a9dba6
PH
650/* Support data structures for Client SMTP Authorization. acl_verify_csa()
651caches its result in a tree to avoid repeated DNS queries. The result is an
652integer code which is used as an index into the following tables of
653explanatory strings and verification return codes. */
654
655static tree_node *csa_cache = NULL;
656
657enum { CSA_UNKNOWN, CSA_OK, CSA_DEFER_SRV, CSA_DEFER_ADDR,
658 CSA_FAIL_EXPLICIT, CSA_FAIL_DOMAIN, CSA_FAIL_NOADDR, CSA_FAIL_MISMATCH };
659
660/* The acl_verify_csa() return code is translated into an acl_verify() return
661code using the following table. It is OK unless the client is definitely not
662authorized. This is because CSA is supposed to be optional for sending sites,
663so recipients should not be too strict about checking it - especially because
664DNS problems are quite likely to occur. It's possible to use $csa_status in
665further ACL conditions to distinguish ok, unknown, and defer if required, but
666the aim is to make the usual configuration simple. */
667
668static int csa_return_code[] = {
669 OK, OK, OK, OK,
670 FAIL, FAIL, FAIL, FAIL
671};
672
673static uschar *csa_status_string[] = {
674 US"unknown", US"ok", US"defer", US"defer",
675 US"fail", US"fail", US"fail", US"fail"
676};
677
678static uschar *csa_reason_string[] = {
679 US"unknown",
680 US"ok",
681 US"deferred (SRV lookup failed)",
682 US"deferred (target address lookup failed)",
683 US"failed (explicit authorization required)",
684 US"failed (host name not authorized)",
685 US"failed (no authorized addresses)",
686 US"failed (client address mismatch)"
687};
688
059ec3d9
PH
689/* Enable recursion between acl_check_internal() and acl_check_condition() */
690
691static int acl_check_internal(int, address_item *, uschar *, int, uschar **,
692 uschar **);
693
694
695/*************************************************
696* Pick out name from list *
697*************************************************/
698
699/* Use a binary chop method
700
701Arguments:
702 name name to find
703 list list of names
704 end size of list
705
706Returns: offset in list, or -1 if not found
707*/
708
709static int
710acl_checkname(uschar *name, uschar **list, int end)
711{
712int start = 0;
713
714while (start < end)
715 {
716 int mid = (start + end)/2;
717 int c = Ustrcmp(name, list[mid]);
718 if (c == 0) return mid;
719 if (c < 0) end = mid; else start = mid + 1;
720 }
721
722return -1;
723}
724
725
726/*************************************************
727* Read and parse one ACL *
728*************************************************/
729
730/* This function is called both from readconf in order to parse the ACLs in the
731configuration file, and also when an ACL is encountered dynamically (e.g. as
732the result of an expansion). It is given a function to call in order to
733retrieve the lines of the ACL. This function handles skipping comments and
734blank lines (where relevant).
735
736Arguments:
737 func function to get next line of ACL
738 error where to put an error message
739
740Returns: pointer to ACL, or NULL
741 NULL can be legal (empty ACL); in this case error will be NULL
742*/
743
744acl_block *
745acl_read(uschar *(*func)(void), uschar **error)
746{
747acl_block *yield = NULL;
748acl_block **lastp = &yield;
749acl_block *this = NULL;
750acl_condition_block *cond;
751acl_condition_block **condp = NULL;
752uschar *s;
753
754*error = NULL;
755
756while ((s = (*func)()) != NULL)
757 {
758 int v, c;
759 BOOL negated = FALSE;
760 uschar *saveline = s;
761 uschar name[64];
762
763 /* Conditions (but not verbs) are allowed to be negated by an initial
764 exclamation mark. */
765
766 while (isspace(*s)) s++;
767 if (*s == '!')
768 {
769 negated = TRUE;
770 s++;
771 }
772
cf00dad6
PH
773 /* Read the name of a verb or a condition, or the start of a new ACL, which
774 can be started by a name, or by a macro definition. */
059ec3d9
PH
775
776 s = readconf_readname(name, sizeof(name), s);
b8dc3e4a 777 if (*s == ':' || (isupper(name[0]) && *s == '=')) return yield;
059ec3d9
PH
778
779 /* If a verb is unrecognized, it may be another condition or modifier that
780 continues the previous verb. */
781
782 v = acl_checkname(name, verbs, sizeof(verbs)/sizeof(char *));
783 if (v < 0)
784 {
785 if (this == NULL)
786 {
4e167a8c
PH
787 *error = string_sprintf("unknown ACL verb \"%s\" in \"%s\"", name,
788 saveline);
059ec3d9
PH
789 return NULL;
790 }
791 }
792
793 /* New verb */
794
795 else
796 {
797 if (negated)
798 {
799 *error = string_sprintf("malformed ACL line \"%s\"", saveline);
800 return NULL;
801 }
802 this = store_get(sizeof(acl_block));
803 *lastp = this;
804 lastp = &(this->next);
805 this->next = NULL;
806 this->verb = v;
807 this->condition = NULL;
808 condp = &(this->condition);
809 if (*s == 0) continue; /* No condition on this line */
810 if (*s == '!')
811 {
812 negated = TRUE;
813 s++;
814 }
815 s = readconf_readname(name, sizeof(name), s); /* Condition name */
816 }
817
818 /* Handle a condition or modifier. */
819
820 c = acl_checkname(name, conditions, sizeof(conditions)/sizeof(char *));
821 if (c < 0)
822 {
823 *error = string_sprintf("unknown ACL condition/modifier in \"%s\"",
824 saveline);
825 return NULL;
826 }
827
828 /* The modifiers may not be negated */
829
830 if (negated && cond_modifiers[c])
831 {
832 *error = string_sprintf("ACL error: negation is not allowed with "
833 "\"%s\"", conditions[c]);
834 return NULL;
835 }
836
837 /* ENDPASS may occur only with ACCEPT or DISCARD. */
838
839 if (c == ACLC_ENDPASS &&
840 this->verb != ACL_ACCEPT &&
841 this->verb != ACL_DISCARD)
842 {
843 *error = string_sprintf("ACL error: \"%s\" is not allowed with \"%s\"",
844 conditions[c], verbs[this->verb]);
845 return NULL;
846 }
847
848 cond = store_get(sizeof(acl_condition_block));
849 cond->next = NULL;
850 cond->type = c;
851 cond->u.negated = negated;
852
853 *condp = cond;
854 condp = &(cond->next);
855
856 /* The "set" modifier is different in that its argument is "name=value"
857 rather than just a value, and we can check the validity of the name, which
38a0a95f
PH
858 gives us a variable name to insert into the data block. The original ACL
859 variable names were acl_c0 ... acl_c9 and acl_m0 ... acl_m9. This was
860 extended to 20 of each type, but after that people successfully argued for
641cb756
PH
861 arbitrary names. In the new scheme, the names must start with acl_c or acl_m.
862 After that, we allow alphanumerics and underscores, but the first character
863 after c or m must be a digit or an underscore. This retains backwards
864 compatibility. */
059ec3d9
PH
865
866 if (c == ACLC_SET)
867 {
47ca6d6c
PH
868 uschar *endptr;
869
38a0a95f
PH
870 if (Ustrncmp(s, "acl_c", 5) != 0 &&
871 Ustrncmp(s, "acl_m", 5) != 0)
47ca6d6c 872 {
38a0a95f
PH
873 *error = string_sprintf("invalid variable name after \"set\" in ACL "
874 "modifier \"set %s\" (must start \"acl_c\" or \"acl_m\")", s);
875 return NULL;
47ca6d6c 876 }
38a0a95f
PH
877
878 endptr = s + 5;
641cb756
PH
879 if (!isdigit(*endptr) && *endptr != '_')
880 {
881 *error = string_sprintf("invalid variable name after \"set\" in ACL "
882 "modifier \"set %s\" (digit or underscore must follow acl_c or acl_m)",
883 s);
884 return NULL;
885 }
886
38a0a95f 887 while (*endptr != 0 && *endptr != '=' && !isspace(*endptr))
47ca6d6c 888 {
38a0a95f
PH
889 if (!isalnum(*endptr) && *endptr != '_')
890 {
891 *error = string_sprintf("invalid character \"%c\" in variable name "
892 "in ACL modifier \"set %s\"", *endptr, s);
893 return NULL;
894 }
895 endptr++;
47ca6d6c 896 }
47ca6d6c 897
38a0a95f 898 cond->u.varname = string_copyn(s + 4, endptr - s - 4);
47ca6d6c 899 s = endptr;
059ec3d9
PH
900 while (isspace(*s)) s++;
901 }
902
903 /* For "set", we are now positioned for the data. For the others, only
904 "endpass" has no data */
905
906 if (c != ACLC_ENDPASS)
907 {
908 if (*s++ != '=')
909 {
910 *error = string_sprintf("\"=\" missing after ACL \"%s\" %s", name,
911 cond_modifiers[c]? US"modifier" : US"condition");
912 return NULL;
913 }
914 while (isspace(*s)) s++;
915 cond->arg = string_copy(s);
916 }
917 }
918
919return yield;
920}
921
922
923
71fafd95
PH
924/*************************************************
925* Set up added header line(s) *
926*************************************************/
927
928/* This function is called by the add_header modifier, and also from acl_warn()
929to implement the now-deprecated way of adding header lines using "message" on a
930"warn" verb. The argument is treated as a sequence of header lines which are
931added to a chain, provided there isn't an identical one already there.
932
933Argument: string of header lines
934Returns: nothing
935*/
936
937static void
938setup_header(uschar *hstring)
939{
940uschar *p, *q;
941int hlen = Ustrlen(hstring);
942
943/* An empty string does nothing; otherwise add a final newline if necessary. */
944
945if (hlen <= 0) return;
946if (hstring[hlen-1] != '\n') hstring = string_sprintf("%s\n", hstring);
947
948/* Loop for multiple header lines, taking care about continuations */
949
950for (p = q = hstring; *p != 0; )
951 {
952 uschar *s;
953 int newtype = htype_add_bot;
954 header_line **hptr = &acl_added_headers;
955
956 /* Find next header line within the string */
957
958 for (;;)
959 {
960 q = Ustrchr(q, '\n');
961 if (*(++q) != ' ' && *q != '\t') break;
962 }
963
964 /* If the line starts with a colon, interpret the instruction for where to
965 add it. This temporarily sets up a new type. */
966
967 if (*p == ':')
968 {
969 if (strncmpic(p, US":after_received:", 16) == 0)
970 {
971 newtype = htype_add_rec;
972 p += 16;
973 }
974 else if (strncmpic(p, US":at_start_rfc:", 14) == 0)
975 {
976 newtype = htype_add_rfc;
977 p += 14;
978 }
979 else if (strncmpic(p, US":at_start:", 10) == 0)
980 {
981 newtype = htype_add_top;
982 p += 10;
983 }
984 else if (strncmpic(p, US":at_end:", 8) == 0)
985 {
986 newtype = htype_add_bot;
987 p += 8;
988 }
989 while (*p == ' ' || *p == '\t') p++;
990 }
991
992 /* See if this line starts with a header name, and if not, add X-ACL-Warn:
993 to the front of it. */
994
995 for (s = p; s < q - 1; s++)
996 {
997 if (*s == ':' || !isgraph(*s)) break;
998 }
999
1000 s = string_sprintf("%s%.*s", (*s == ':')? "" : "X-ACL-Warn: ", q - p, p);
1001 hlen = Ustrlen(s);
1002
1003 /* See if this line has already been added */
1004
1005 while (*hptr != NULL)
1006 {
1007 if (Ustrncmp((*hptr)->text, s, hlen) == 0) break;
1008 hptr = &((*hptr)->next);
1009 }
1010
1011 /* Add if not previously present */
1012
1013 if (*hptr == NULL)
1014 {
1015 header_line *h = store_get(sizeof(header_line));
1016 h->text = s;
1017 h->next = NULL;
1018 h->type = newtype;
1019 h->slen = hlen;
1020 *hptr = h;
1021 hptr = &(h->next);
1022 }
1023
1024 /* Advance for next header line within the string */
1025
1026 p = q;
1027 }
1028}
1029
1030
1031
1032
059ec3d9
PH
1033/*************************************************
1034* Handle warnings *
1035*************************************************/
1036
1037/* This function is called when a WARN verb's conditions are true. It adds to
1038the message's headers, and/or writes information to the log. In each case, this
1039only happens once (per message for headers, per connection for log).
1040
71fafd95
PH
1041** NOTE: The header adding action using the "message" setting is historic, and
1042its use is now deprecated. The new add_header modifier should be used instead.
1043
059ec3d9
PH
1044Arguments:
1045 where ACL_WHERE_xxxx indicating which ACL this is
1046 user_message message for adding to headers
1047 log_message message for logging, if different
1048
1049Returns: nothing
1050*/
1051
1052static void
1053acl_warn(int where, uschar *user_message, uschar *log_message)
1054{
059ec3d9
PH
1055if (log_message != NULL && log_message != user_message)
1056 {
1057 uschar *text;
1058 string_item *logged;
1059
1060 text = string_sprintf("%s Warning: %s", host_and_ident(TRUE),
1061 string_printing(log_message));
1062
1063 /* If a sender verification has failed, and the log message is "sender verify
1064 failed", add the failure message. */
1065
1066 if (sender_verified_failed != NULL &&
1067 sender_verified_failed->message != NULL &&
1068 strcmpic(log_message, US"sender verify failed") == 0)
1069 text = string_sprintf("%s: %s", text, sender_verified_failed->message);
1070
9c7a242c
PH
1071 /* Search previously logged warnings. They are kept in malloc
1072 store so they can be freed at the start of a new message. */
059ec3d9
PH
1073
1074 for (logged = acl_warn_logged; logged != NULL; logged = logged->next)
1075 if (Ustrcmp(logged->text, text) == 0) break;
1076
1077 if (logged == NULL)
1078 {
1079 int length = Ustrlen(text) + 1;
1080 log_write(0, LOG_MAIN, "%s", text);
1081 logged = store_malloc(sizeof(string_item) + length);
1082 logged->text = (uschar *)logged + sizeof(string_item);
1083 memcpy(logged->text, text, length);
1084 logged->next = acl_warn_logged;
1085 acl_warn_logged = logged;
1086 }
1087 }
1088
1089/* If there's no user message, we are done. */
1090
1091if (user_message == NULL) return;
1092
1093/* If this isn't a message ACL, we can't do anything with a user message.
1094Log an error. */
1095
1096if (where > ACL_WHERE_NOTSMTP)
1097 {
1098 log_write(0, LOG_MAIN|LOG_PANIC, "ACL \"warn\" with \"message\" setting "
1099 "found in a non-message (%s) ACL: cannot specify header lines here: "
1100 "message ignored", acl_wherenames[where]);
1101 return;
1102 }
1103
71fafd95
PH
1104/* The code for setting up header lines is now abstracted into a separate
1105function so that it can be used for the add_header modifier as well. */
059ec3d9 1106
71fafd95 1107setup_header(user_message);
059ec3d9
PH
1108}
1109
1110
1111
1112/*************************************************
1113* Verify and check reverse DNS *
1114*************************************************/
1115
1116/* Called from acl_verify() below. We look up the host name(s) of the client IP
1117address if this has not yet been done. The host_name_lookup() function checks
1118that one of these names resolves to an address list that contains the client IP
1119address, so we don't actually have to do the check here.
1120
1121Arguments:
1122 user_msgptr pointer for user message
1123 log_msgptr pointer for log message
1124
1125Returns: OK verification condition succeeded
1126 FAIL verification failed
1127 DEFER there was a problem verifying
1128*/
1129
1130static int
1131acl_verify_reverse(uschar **user_msgptr, uschar **log_msgptr)
1132{
1133int rc;
1134
1135user_msgptr = user_msgptr; /* stop compiler warning */
1136
1137/* Previous success */
1138
1139if (sender_host_name != NULL) return OK;
1140
1141/* Previous failure */
1142
1143if (host_lookup_failed)
1144 {
1145 *log_msgptr = string_sprintf("host lookup failed%s", host_lookup_msg);
1146 return FAIL;
1147 }
1148
1149/* Need to do a lookup */
1150
1151HDEBUG(D_acl)
1152 debug_printf("looking up host name to force name/address consistency check\n");
1153
1154if ((rc = host_name_lookup()) != OK)
1155 {
1156 *log_msgptr = (rc == DEFER)?
1157 US"host lookup deferred for reverse lookup check"
1158 :
1159 string_sprintf("host lookup failed for reverse lookup check%s",
1160 host_lookup_msg);
1161 return rc; /* DEFER or FAIL */
1162 }
1163
1164host_build_sender_fullhost();
1165return OK;
1166}
1167
1168
1169
e5a9dba6
PH
1170/*************************************************
1171* Check client IP address matches CSA target *
1172*************************************************/
1173
1174/* Called from acl_verify_csa() below. This routine scans a section of a DNS
1175response for address records belonging to the CSA target hostname. The section
1176is specified by the reset argument, either RESET_ADDITIONAL or RESET_ANSWERS.
1177If one of the addresses matches the client's IP address, then the client is
1178authorized by CSA. If there are target IP addresses but none of them match
1179then the client is using an unauthorized IP address. If there are no target IP
1180addresses then the client cannot be using an authorized IP address. (This is
1181an odd configuration - why didn't the SRV record have a weight of 1 instead?)
1182
1183Arguments:
1184 dnsa the DNS answer block
1185 dnss a DNS scan block for us to use
1186 reset option specifing what portion to scan, as described above
1187 target the target hostname to use for matching RR names
1188
1189Returns: CSA_OK successfully authorized
1190 CSA_FAIL_MISMATCH addresses found but none matched
1191 CSA_FAIL_NOADDR no target addresses found
1192*/
1193
1194static int
1195acl_verify_csa_address(dns_answer *dnsa, dns_scan *dnss, int reset,
1196 uschar *target)
1197{
1198dns_record *rr;
1199dns_address *da;
1200
1201BOOL target_found = FALSE;
1202
1203for (rr = dns_next_rr(dnsa, dnss, reset);
1204 rr != NULL;
1205 rr = dns_next_rr(dnsa, dnss, RESET_NEXT))
1206 {
1207 /* Check this is an address RR for the target hostname. */
1208
1209 if (rr->type != T_A
1210 #if HAVE_IPV6
1211 && rr->type != T_AAAA
1212 #ifdef SUPPORT_A6
1213 && rr->type != T_A6
1214 #endif
1215 #endif
1216 ) continue;
1217
1218 if (strcmpic(target, rr->name) != 0) continue;
1219
1220 target_found = TRUE;
1221
1222 /* Turn the target address RR into a list of textual IP addresses and scan
1223 the list. There may be more than one if it is an A6 RR. */
1224
1225 for (da = dns_address_from_rr(dnsa, rr); da != NULL; da = da->next)
1226 {
1227 /* If the client IP address matches the target IP address, it's good! */
1228
1229 DEBUG(D_acl) debug_printf("CSA target address is %s\n", da->address);
1230
1231 if (strcmpic(sender_host_address, da->address) == 0) return CSA_OK;
1232 }
1233 }
1234
1235/* If we found some target addresses but none of them matched, the client is
1236using an unauthorized IP address, otherwise the target has no authorized IP
1237addresses. */
1238
1239if (target_found) return CSA_FAIL_MISMATCH;
1240else return CSA_FAIL_NOADDR;
1241}
1242
1243
1244
1245/*************************************************
1246* Verify Client SMTP Authorization *
1247*************************************************/
1248
1249/* Called from acl_verify() below. This routine calls dns_lookup_special()
1250to find the CSA SRV record corresponding to the domain argument, or
1251$sender_helo_name if no argument is provided. It then checks that the
1252client is authorized, and that its IP address corresponds to the SRV
1253target's address by calling acl_verify_csa_address() above. The address
1254should have been returned in the DNS response's ADDITIONAL section, but if
1255not we perform another DNS lookup to get it.
1256
1257Arguments:
1258 domain pointer to optional parameter following verify = csa
1259
1260Returns: CSA_UNKNOWN no valid CSA record found
1261 CSA_OK successfully authorized
1262 CSA_FAIL_* client is definitely not authorized
1263 CSA_DEFER_* there was a DNS problem
1264*/
1265
1266static int
1267acl_verify_csa(uschar *domain)
1268{
1269tree_node *t;
1270uschar *found, *p;
1271int priority, weight, port;
1272dns_answer dnsa;
1273dns_scan dnss;
1274dns_record *rr;
1275int rc, type;
1276uschar target[256];
1277
1278/* Work out the domain we are using for the CSA lookup. The default is the
1279client's HELO domain. If the client has not said HELO, use its IP address
1280instead. If it's a local client (exim -bs), CSA isn't applicable. */
1281
1282while (isspace(*domain) && *domain != '\0') ++domain;
1283if (*domain == '\0') domain = sender_helo_name;
1284if (domain == NULL) domain = sender_host_address;
1285if (sender_host_address == NULL) return CSA_UNKNOWN;
1286
1287/* If we have an address literal, strip off the framing ready for turning it
1288into a domain. The framing consists of matched square brackets possibly
1289containing a keyword and a colon before the actual IP address. */
1290
1291if (domain[0] == '[')
1292 {
1293 uschar *start = Ustrchr(domain, ':');
1294 if (start == NULL) start = domain;
1295 domain = string_copyn(start + 1, Ustrlen(start) - 2);
1296 }
1297
1298/* Turn domains that look like bare IP addresses into domains in the reverse
1299DNS. This code also deals with address literals and $sender_host_address. It's
1300not quite kosher to treat bare domains such as EHLO 192.0.2.57 the same as
1301address literals, but it's probably the most friendly thing to do. This is an
1302extension to CSA, so we allow it to be turned off for proper conformance. */
1303
7e66e54d 1304if (string_is_ip_address(domain, NULL) != 0)
e5a9dba6
PH
1305 {
1306 if (!dns_csa_use_reverse) return CSA_UNKNOWN;
1307 dns_build_reverse(domain, target);
1308 domain = target;
1309 }
1310
1311/* Find out if we've already done the CSA check for this domain. If we have,
1312return the same result again. Otherwise build a new cached result structure
1313for this domain. The name is filled in now, and the value is filled in when
1314we return from this function. */
1315
1316t = tree_search(csa_cache, domain);
1317if (t != NULL) return t->data.val;
1318
1319t = store_get_perm(sizeof(tree_node) + Ustrlen(domain));
1320Ustrcpy(t->name, domain);
1321(void)tree_insertnode(&csa_cache, t);
1322
1323/* Now we are ready to do the actual DNS lookup(s). */
1324
28e6ef29 1325found = domain;
e5a9dba6
PH
1326switch (dns_special_lookup(&dnsa, domain, T_CSA, &found))
1327 {
1328 /* If something bad happened (most commonly DNS_AGAIN), defer. */
1329
1330 default:
1331 return t->data.val = CSA_DEFER_SRV;
1332
1333 /* If we found nothing, the client's authorization is unknown. */
1334
1335 case DNS_NOMATCH:
1336 case DNS_NODATA:
1337 return t->data.val = CSA_UNKNOWN;
1338
1339 /* We got something! Go on to look at the reply in more detail. */
1340
1341 case DNS_SUCCEED:
1342 break;
1343 }
1344
1345/* Scan the reply for well-formed CSA SRV records. */
1346
1347for (rr = dns_next_rr(&dnsa, &dnss, RESET_ANSWERS);
1348 rr != NULL;
1349 rr = dns_next_rr(&dnsa, &dnss, RESET_NEXT))
1350 {
1351 if (rr->type != T_SRV) continue;
1352
1353 /* Extract the numerical SRV fields (p is incremented) */
1354
1355 p = rr->data;
1356 GETSHORT(priority, p);
1357 GETSHORT(weight, p);
1358 GETSHORT(port, p);
1359
1360 DEBUG(D_acl)
1361 debug_printf("CSA priority=%d weight=%d port=%d\n", priority, weight, port);
1362
1363 /* Check the CSA version number */
1364
1365 if (priority != 1) continue;
1366
1367 /* If the domain does not have a CSA SRV record of its own (i.e. the domain
1368 found by dns_special_lookup() is a parent of the one we asked for), we check
1369 the subdomain assertions in the port field. At the moment there's only one
1370 assertion: legitimate SMTP clients are all explicitly authorized with CSA
1371 SRV records of their own. */
1372
1373 if (found != domain)
1374 {
1375 if (port & 1)
1376 return t->data.val = CSA_FAIL_EXPLICIT;
1377 else
1378 return t->data.val = CSA_UNKNOWN;
1379 }
1380
1381 /* This CSA SRV record refers directly to our domain, so we check the value
1382 in the weight field to work out the domain's authorization. 0 and 1 are
1383 unauthorized; 3 means the client is authorized but we can't check the IP
1384 address in order to authenticate it, so we treat it as unknown; values
1385 greater than 3 are undefined. */
1386
1387 if (weight < 2) return t->data.val = CSA_FAIL_DOMAIN;
1388
1389 if (weight > 2) continue;
1390
1391 /* Weight == 2, which means the domain is authorized. We must check that the
1392 client's IP address is listed as one of the SRV target addresses. Save the
1393 target hostname then break to scan the additional data for its addresses. */
1394
1395 (void)dn_expand(dnsa.answer, dnsa.answer + dnsa.answerlen, p,
1396 (DN_EXPAND_ARG4_TYPE)target, sizeof(target));
1397
1398 DEBUG(D_acl) debug_printf("CSA target is %s\n", target);
1399
1400 break;
1401 }
1402
1403/* If we didn't break the loop then no appropriate records were found. */
1404
1405if (rr == NULL) return t->data.val = CSA_UNKNOWN;
1406
1407/* Do not check addresses if the target is ".", in accordance with RFC 2782.
1408A target of "." indicates there are no valid addresses, so the client cannot
1409be authorized. (This is an odd configuration because weight=2 target=. is
1410equivalent to weight=1, but we check for it in order to keep load off the
1411root name servers.) Note that dn_expand() turns "." into "". */
1412
1413if (Ustrcmp(target, "") == 0) return t->data.val = CSA_FAIL_NOADDR;
1414
1415/* Scan the additional section of the CSA SRV reply for addresses belonging
1416to the target. If the name server didn't return any additional data (e.g.
1417because it does not fully support SRV records), we need to do another lookup
1418to obtain the target addresses; otherwise we have a definitive result. */
1419
1420rc = acl_verify_csa_address(&dnsa, &dnss, RESET_ADDITIONAL, target);
1421if (rc != CSA_FAIL_NOADDR) return t->data.val = rc;
1422
1423/* The DNS lookup type corresponds to the IP version used by the client. */
1424
1425#if HAVE_IPV6
1426if (Ustrchr(sender_host_address, ':') != NULL)
1427 type = T_AAAA;
1428else
1429#endif /* HAVE_IPV6 */
1430 type = T_A;
1431
1432
1433#if HAVE_IPV6 && defined(SUPPORT_A6)
1434DNS_LOOKUP_AGAIN:
1435#endif
1436
1437switch (dns_lookup(&dnsa, target, type, NULL))
1438 {
1439 /* If something bad happened (most commonly DNS_AGAIN), defer. */
1440
1441 default:
1442 return t->data.val = CSA_DEFER_ADDR;
1443
1444 /* If the query succeeded, scan the addresses and return the result. */
1445
1446 case DNS_SUCCEED:
1447 rc = acl_verify_csa_address(&dnsa, &dnss, RESET_ANSWERS, target);
1448 if (rc != CSA_FAIL_NOADDR) return t->data.val = rc;
1449 /* else fall through */
1450
1451 /* If the target has no IP addresses, the client cannot have an authorized
1452 IP address. However, if the target site uses A6 records (not AAAA records)
1453 we have to do yet another lookup in order to check them. */
1454
1455 case DNS_NOMATCH:
1456 case DNS_NODATA:
1457
1458 #if HAVE_IPV6 && defined(SUPPORT_A6)
1459 if (type == T_AAAA) { type = T_A6; goto DNS_LOOKUP_AGAIN; }
1460 #endif
1461
1462 return t->data.val = CSA_FAIL_NOADDR;
1463 }
1464}
1465
1466
1467
059ec3d9
PH
1468/*************************************************
1469* Handle verification (address & other) *
1470*************************************************/
1471
1472/* This function implements the "verify" condition. It is called when
1473encountered in any ACL, because some tests are almost always permitted. Some
1474just don't make sense, and always fail (for example, an attempt to test a host
1475lookup for a non-TCP/IP message). Others are restricted to certain ACLs.
1476
1477Arguments:
1478 where where called from
1479 addr the recipient address that the ACL is handling, or NULL
1480 arg the argument of "verify"
1481 user_msgptr pointer for user message
1482 log_msgptr pointer for log message
1483 basic_errno where to put verify errno
1484
1485Returns: OK verification condition succeeded
1486 FAIL verification failed
1487 DEFER there was a problem verifying
1488 ERROR syntax error
1489*/
1490
1491static int
1492acl_verify(int where, address_item *addr, uschar *arg,
1493 uschar **user_msgptr, uschar **log_msgptr, int *basic_errno)
1494{
1495int sep = '/';
1496int callout = -1;
1497int callout_overall = -1;
4deaf07d 1498int callout_connect = -1;
059ec3d9
PH
1499int verify_options = 0;
1500int rc;
1501BOOL verify_header_sender = FALSE;
1502BOOL defer_ok = FALSE;
1503BOOL callout_defer_ok = FALSE;
1504BOOL no_details = FALSE;
eafd343b 1505BOOL success_on_redirect = FALSE;
059ec3d9
PH
1506address_item *sender_vaddr = NULL;
1507uschar *verify_sender_address = NULL;
1508uschar *pm_mailfrom = NULL;
1509uschar *se_mailfrom = NULL;
596875b3
PH
1510
1511/* Some of the verify items have slash-separated options; some do not. Diagnose
1512an error if options are given for items that don't expect them. This code has
1513now got very message. Refactoring to use a table would be a good idea one day.
1514*/
1515
1516uschar *slash = Ustrchr(arg, '/');
059ec3d9
PH
1517uschar *list = arg;
1518uschar *ss = string_nextinlist(&list, &sep, big_buffer, big_buffer_size);
1519
1520if (ss == NULL) goto BAD_VERIFY;
1521
1522/* Handle name/address consistency verification in a separate function. */
1523
1524if (strcmpic(ss, US"reverse_host_lookup") == 0)
1525 {
596875b3 1526 if (slash != NULL) goto NO_OPTIONS;
059ec3d9
PH
1527 if (sender_host_address == NULL) return OK;
1528 return acl_verify_reverse(user_msgptr, log_msgptr);
1529 }
1530
1531/* TLS certificate verification is done at STARTTLS time; here we just
1532test whether it was successful or not. (This is for optional verification; for
1533mandatory verification, the connection doesn't last this long.) */
1534
1535if (strcmpic(ss, US"certificate") == 0)
1536 {
596875b3 1537 if (slash != NULL) goto NO_OPTIONS;
059ec3d9
PH
1538 if (tls_certificate_verified) return OK;
1539 *user_msgptr = US"no verified certificate";
1540 return FAIL;
1541 }
1542
d7b47fd0
PH
1543/* We can test the result of optional HELO verification that might have
1544occurred earlier. If not, we can attempt the verification now. */
059ec3d9 1545
596875b3
PH
1546if (strcmpic(ss, US"helo") == 0)
1547 {
1548 if (slash != NULL) goto NO_OPTIONS;
0154e85a
TF
1549 if (!helo_verified && !helo_verify_failed) smtp_verify_helo();
1550 return helo_verified? OK : FAIL;
596875b3 1551 }
059ec3d9 1552
e5a9dba6
PH
1553/* Do Client SMTP Authorization checks in a separate function, and turn the
1554result code into user-friendly strings. */
1555
1556if (strcmpic(ss, US"csa") == 0)
1557 {
1558 rc = acl_verify_csa(list);
1559 *log_msgptr = *user_msgptr = string_sprintf("client SMTP authorization %s",
1560 csa_reason_string[rc]);
1561 csa_status = csa_status_string[rc];
1562 DEBUG(D_acl) debug_printf("CSA result %s\n", csa_status);
1563 return csa_return_code[rc];
1564 }
1565
596875b3
PH
1566/* Check that all relevant header lines have the correct syntax. If there is
1567a syntax error, we return details of the error to the sender if configured to
1568send out full details. (But a "message" setting on the ACL can override, as
1569always). */
059ec3d9 1570
596875b3 1571if (strcmpic(ss, US"header_syntax") == 0)
059ec3d9 1572 {
596875b3 1573 if (slash != NULL) goto NO_OPTIONS;
1c41c9cc 1574 if (where != ACL_WHERE_DATA && where != ACL_WHERE_NOTSMTP) goto WRONG_ACL;
596875b3
PH
1575 rc = verify_check_headers(log_msgptr);
1576 if (rc != OK && smtp_return_error_details && *log_msgptr != NULL)
1577 *user_msgptr = string_sprintf("Rejected after DATA: %s", *log_msgptr);
1578 return rc;
1579 }
059ec3d9 1580
1c41c9cc
PH
1581/* Check that no recipient of this message is "blind", that is, every envelope
1582recipient must be mentioned in either To: or Cc:. */
1583
1584if (strcmpic(ss, US"not_blind") == 0)
1585 {
1586 if (slash != NULL) goto NO_OPTIONS;
1587 if (where != ACL_WHERE_DATA && where != ACL_WHERE_NOTSMTP) goto WRONG_ACL;
1588 rc = verify_check_notblind();
1589 if (rc != OK)
1590 {
1591 *log_msgptr = string_sprintf("bcc recipient detected");
1592 if (smtp_return_error_details)
1593 *user_msgptr = string_sprintf("Rejected after DATA: %s", *log_msgptr);
1594 }
1595 return rc;
1596 }
059ec3d9 1597
596875b3
PH
1598/* The remaining verification tests check recipient and sender addresses,
1599either from the envelope or from the header. There are a number of
1600slash-separated options that are common to all of them. */
059ec3d9 1601
059ec3d9 1602
596875b3
PH
1603/* Check that there is at least one verifiable sender address in the relevant
1604header lines. This can be followed by callout and defer options, just like
1605sender and recipient. */
059ec3d9 1606
596875b3
PH
1607if (strcmpic(ss, US"header_sender") == 0)
1608 {
1c41c9cc 1609 if (where != ACL_WHERE_DATA && where != ACL_WHERE_NOTSMTP) goto WRONG_ACL;
596875b3 1610 verify_header_sender = TRUE;
059ec3d9
PH
1611 }
1612
1613/* Otherwise, first item in verify argument must be "sender" or "recipient".
1614In the case of a sender, this can optionally be followed by an address to use
1615in place of the actual sender (rare special-case requirement). */
1616
1617else if (strncmpic(ss, US"sender", 6) == 0)
1618 {
1619 uschar *s = ss + 6;
1620 if (where > ACL_WHERE_NOTSMTP)
1621 {
1622 *log_msgptr = string_sprintf("cannot verify sender in ACL for %s "
1623 "(only possible for MAIL, RCPT, PREDATA, or DATA)",
1624 acl_wherenames[where]);
1625 return ERROR;
1626 }
1627 if (*s == 0)
1628 verify_sender_address = sender_address;
1629 else
1630 {
1631 while (isspace(*s)) s++;
1632 if (*s++ != '=') goto BAD_VERIFY;
1633 while (isspace(*s)) s++;
1634 verify_sender_address = string_copy(s);
1635 }
1636 }
1637else
1638 {
1639 if (strcmpic(ss, US"recipient") != 0) goto BAD_VERIFY;
1640 if (addr == NULL)
1641 {
1642 *log_msgptr = string_sprintf("cannot verify recipient in ACL for %s "
1643 "(only possible for RCPT)", acl_wherenames[where]);
1644 return ERROR;
1645 }
1646 }
1647
596875b3
PH
1648/* Remaining items are optional; they apply to sender and recipient
1649verification, including "header sender" verification. */
059ec3d9
PH
1650
1651while ((ss = string_nextinlist(&list, &sep, big_buffer, big_buffer_size))
1652 != NULL)
1653 {
1654 if (strcmpic(ss, US"defer_ok") == 0) defer_ok = TRUE;
1655 else if (strcmpic(ss, US"no_details") == 0) no_details = TRUE;
eafd343b 1656 else if (strcmpic(ss, US"success_on_redirect") == 0) success_on_redirect = TRUE;
059ec3d9
PH
1657
1658 /* These two old options are left for backwards compatibility */
1659
1660 else if (strcmpic(ss, US"callout_defer_ok") == 0)
1661 {
1662 callout_defer_ok = TRUE;
1663 if (callout == -1) callout = CALLOUT_TIMEOUT_DEFAULT;
1664 }
1665
1666 else if (strcmpic(ss, US"check_postmaster") == 0)
1667 {
1668 pm_mailfrom = US"";
1669 if (callout == -1) callout = CALLOUT_TIMEOUT_DEFAULT;
1670 }
1671
1672 /* The callout option has a number of sub-options, comma separated */
1673
1674 else if (strncmpic(ss, US"callout", 7) == 0)
1675 {
1676 callout = CALLOUT_TIMEOUT_DEFAULT;
1677 ss += 7;
1678 if (*ss != 0)
1679 {
1680 while (isspace(*ss)) ss++;
1681 if (*ss++ == '=')
1682 {
1683 int optsep = ',';
1684 uschar *opt;
1685 uschar buffer[256];
1686 while (isspace(*ss)) ss++;
8e669ac1
PH
1687
1688 /* This callout option handling code has become a mess as new options
1689 have been added in an ad hoc manner. It should be tidied up into some
4deaf07d 1690 kind of table-driven thing. */
8e669ac1 1691
059ec3d9
PH
1692 while ((opt = string_nextinlist(&ss, &optsep, buffer, sizeof(buffer)))
1693 != NULL)
1694 {
1695 if (strcmpic(opt, US"defer_ok") == 0) callout_defer_ok = TRUE;
1696 else if (strcmpic(opt, US"no_cache") == 0)
1697 verify_options |= vopt_callout_no_cache;
1698 else if (strcmpic(opt, US"random") == 0)
1699 verify_options |= vopt_callout_random;
1700 else if (strcmpic(opt, US"use_sender") == 0)
1701 verify_options |= vopt_callout_recipsender;
1702 else if (strcmpic(opt, US"use_postmaster") == 0)
1703 verify_options |= vopt_callout_recippmaster;
1704 else if (strcmpic(opt, US"postmaster") == 0) pm_mailfrom = US"";
2a4be8f9
PH
1705 else if (strcmpic(opt, US"fullpostmaster") == 0)
1706 {
1707 pm_mailfrom = US"";
1708 verify_options |= vopt_callout_fullpm;
1709 }
059ec3d9
PH
1710
1711 else if (strncmpic(opt, US"mailfrom", 8) == 0)
1712 {
1713 if (!verify_header_sender)
1714 {
1715 *log_msgptr = string_sprintf("\"mailfrom\" is allowed as a "
1716 "callout option only for verify=header_sender (detected in ACL "
1717 "condition \"%s\")", arg);
1718 return ERROR;
1719 }
1720 opt += 8;
1721 while (isspace(*opt)) opt++;
1722 if (*opt++ != '=')
1723 {
1724 *log_msgptr = string_sprintf("'=' expected after "
1725 "\"mailfrom\" in ACL condition \"%s\"", arg);
1726 return ERROR;
1727 }
1728 while (isspace(*opt)) opt++;
1729 se_mailfrom = string_copy(opt);
1730 }
1731
1732 else if (strncmpic(opt, US"postmaster_mailfrom", 19) == 0)
1733 {
1734 opt += 19;
1735 while (isspace(*opt)) opt++;
1736 if (*opt++ != '=')
1737 {
1738 *log_msgptr = string_sprintf("'=' expected after "
1739 "\"postmaster_mailfrom\" in ACL condition \"%s\"", arg);
1740 return ERROR;
1741 }
1742 while (isspace(*opt)) opt++;
1743 pm_mailfrom = string_copy(opt);
1744 }
1745
1746 else if (strncmpic(opt, US"maxwait", 7) == 0)
1747 {
1748 opt += 7;
1749 while (isspace(*opt)) opt++;
1750 if (*opt++ != '=')
1751 {
1752 *log_msgptr = string_sprintf("'=' expected after \"maxwait\" in "
1753 "ACL condition \"%s\"", arg);
1754 return ERROR;
1755 }
1756 while (isspace(*opt)) opt++;
1757 callout_overall = readconf_readtime(opt, 0, FALSE);
1758 if (callout_overall < 0)
1759 {
1760 *log_msgptr = string_sprintf("bad time value in ACL condition "
1761 "\"verify %s\"", arg);
1762 return ERROR;
1763 }
1764 }
4deaf07d
PH
1765 else if (strncmpic(opt, US"connect", 7) == 0)
1766 {
1767 opt += 7;
1768 while (isspace(*opt)) opt++;
1769 if (*opt++ != '=')
1770 {
1771 *log_msgptr = string_sprintf("'=' expected after "
1772 "\"callout_overaall\" in ACL condition \"%s\"", arg);
1773 return ERROR;
1774 }
1775 while (isspace(*opt)) opt++;
1776 callout_connect = readconf_readtime(opt, 0, FALSE);
1777 if (callout_connect < 0)
1778 {
1779 *log_msgptr = string_sprintf("bad time value in ACL condition "
1780 "\"verify %s\"", arg);
1781 return ERROR;
1782 }
1783 }
059ec3d9
PH
1784 else /* Plain time is callout connect/command timeout */
1785 {
1786 callout = readconf_readtime(opt, 0, FALSE);
1787 if (callout < 0)
1788 {
1789 *log_msgptr = string_sprintf("bad time value in ACL condition "
1790 "\"verify %s\"", arg);
1791 return ERROR;
1792 }
1793 }
1794 }
1795 }
1796 else
1797 {
1798 *log_msgptr = string_sprintf("'=' expected after \"callout\" in "
1799 "ACL condition \"%s\"", arg);
1800 return ERROR;
1801 }
1802 }
1803 }
1804
1805 /* Option not recognized */
1806
1807 else
1808 {
1809 *log_msgptr = string_sprintf("unknown option \"%s\" in ACL "
1810 "condition \"verify %s\"", ss, arg);
1811 return ERROR;
1812 }
1813 }
1814
1815if ((verify_options & (vopt_callout_recipsender|vopt_callout_recippmaster)) ==
1816 (vopt_callout_recipsender|vopt_callout_recippmaster))
1817 {
1818 *log_msgptr = US"only one of use_sender and use_postmaster can be set "
1819 "for a recipient callout";
1820 return ERROR;
1821 }
1822
1823/* Handle sender-in-header verification. Default the user message to the log
1824message if giving out verification details. */
1825
1826if (verify_header_sender)
1827 {
8e669ac1 1828 int verrno;
059ec3d9 1829 rc = verify_check_header_address(user_msgptr, log_msgptr, callout,
fe5b5d0b
PH
1830 callout_overall, callout_connect, se_mailfrom, pm_mailfrom, verify_options,
1831 &verrno);
1832 if (rc != OK)
8e669ac1 1833 {
fe5b5d0b
PH
1834 *basic_errno = verrno;
1835 if (smtp_return_error_details)
1836 {
1837 if (*user_msgptr == NULL && *log_msgptr != NULL)
1838 *user_msgptr = string_sprintf("Rejected after DATA: %s", *log_msgptr);
1839 if (rc == DEFER) acl_temp_details = TRUE;
1840 }
8e669ac1 1841 }
059ec3d9
PH
1842 }
1843
1844/* Handle a sender address. The default is to verify *the* sender address, but
1845optionally a different address can be given, for special requirements. If the
1846address is empty, we are dealing with a bounce message that has no sender, so
1847we cannot do any checking. If the real sender address gets rewritten during
1848verification (e.g. DNS widening), set the flag to stop it being rewritten again
1849during message reception.
1850
1851A list of verified "sender" addresses is kept to try to avoid doing to much
1852work repetitively when there are multiple recipients in a message and they all
1853require sender verification. However, when callouts are involved, it gets too
1854complicated because different recipients may require different callout options.
1855Therefore, we always do a full sender verify when any kind of callout is
1856specified. Caching elsewhere, for instance in the DNS resolver and in the
1857callout handling, should ensure that this is not terribly inefficient. */
1858
1859else if (verify_sender_address != NULL)
1860 {
1861 if ((verify_options & (vopt_callout_recipsender|vopt_callout_recippmaster))
1862 != 0)
1863 {
1864 *log_msgptr = US"use_sender or use_postmaster cannot be used for a "
1865 "sender verify callout";
1866 return ERROR;
1867 }
1868
1869 sender_vaddr = verify_checked_sender(verify_sender_address);
1870 if (sender_vaddr != NULL && /* Previously checked */
1871 callout <= 0) /* No callout needed this time */
1872 {
1873 /* If the "routed" flag is set, it means that routing worked before, so
1874 this check can give OK (the saved return code value, if set, belongs to a
1875 callout that was done previously). If the "routed" flag is not set, routing
1876 must have failed, so we use the saved return code. */
1877
1878 if (testflag(sender_vaddr, af_verify_routed)) rc = OK; else
1879 {
1880 rc = sender_vaddr->special_action;
1881 *basic_errno = sender_vaddr->basic_errno;
1882 }
1883 HDEBUG(D_acl) debug_printf("using cached sender verify result\n");
1884 }
1885
1886 /* Do a new verification, and cache the result. The cache is used to avoid
1887 verifying the sender multiple times for multiple RCPTs when callouts are not
1888 specified (see comments above).
1889
1890 The cache is also used on failure to give details in response to the first
1891 RCPT that gets bounced for this reason. However, this can be suppressed by
1892 the no_details option, which sets the flag that says "this detail has already
1893 been sent". The cache normally contains just one address, but there may be
1894 more in esoteric circumstances. */
1895
1896 else
1897 {
1898 BOOL routed = TRUE;
2a3eea10 1899 uschar *save_address_data = deliver_address_data;
8e669ac1 1900
059ec3d9
PH
1901 sender_vaddr = deliver_make_addr(verify_sender_address, TRUE);
1902 if (no_details) setflag(sender_vaddr, af_sverify_told);
1903 if (verify_sender_address[0] != 0)
1904 {
1905 /* If this is the real sender address, save the unrewritten version
1906 for use later in receive. Otherwise, set a flag so that rewriting the
1907 sender in verify_address() does not update sender_address. */
1908
1909 if (verify_sender_address == sender_address)
1910 sender_address_unrewritten = sender_address;
1911 else
1912 verify_options |= vopt_fake_sender;
1913
eafd343b
TK
1914 if (success_on_redirect)
1915 verify_options |= vopt_success_on_redirect;
1916
059ec3d9
PH
1917 /* The recipient, qualify, and expn options are never set in
1918 verify_options. */
1919
1920 rc = verify_address(sender_vaddr, NULL, verify_options, callout,
4deaf07d 1921 callout_overall, callout_connect, se_mailfrom, pm_mailfrom, &routed);
059ec3d9
PH
1922
1923 HDEBUG(D_acl) debug_printf("----------- end verify ------------\n");
1924
1925 if (rc == OK)
1926 {
1927 if (Ustrcmp(sender_vaddr->address, verify_sender_address) != 0)
1928 {
1929 DEBUG(D_acl) debug_printf("sender %s verified ok as %s\n",
1930 verify_sender_address, sender_vaddr->address);
1931 }
1932 else
1933 {
1934 DEBUG(D_acl) debug_printf("sender %s verified ok\n",
1935 verify_sender_address);
1936 }
1937 }
1938 else *basic_errno = sender_vaddr->basic_errno;
1939 }
1940 else rc = OK; /* Null sender */
1941
1942 /* Cache the result code */
1943
1944 if (routed) setflag(sender_vaddr, af_verify_routed);
1945 if (callout > 0) setflag(sender_vaddr, af_verify_callout);
1946 sender_vaddr->special_action = rc;
1947 sender_vaddr->next = sender_verified_list;
1948 sender_verified_list = sender_vaddr;
8e669ac1
PH
1949
1950 /* Restore the recipient address data, which might have been clobbered by
2a3eea10 1951 the sender verification. */
8e669ac1 1952
2a3eea10 1953 deliver_address_data = save_address_data;
059ec3d9 1954 }
8e669ac1 1955
2a3eea10
PH
1956 /* Put the sender address_data value into $sender_address_data */
1957
8e669ac1 1958 sender_address_data = sender_vaddr->p.address_data;
059ec3d9
PH
1959 }
1960
1961/* A recipient address just gets a straightforward verify; again we must handle
1962the DEFER overrides. */
1963
1964else
1965 {
1966 address_item addr2;
1967
eafd343b
TK
1968 if (success_on_redirect)
1969 verify_options |= vopt_success_on_redirect;
1970
059ec3d9
PH
1971 /* We must use a copy of the address for verification, because it might
1972 get rewritten. */
1973
1974 addr2 = *addr;
1975 rc = verify_address(&addr2, NULL, verify_options|vopt_is_recipient, callout,
4deaf07d 1976 callout_overall, callout_connect, se_mailfrom, pm_mailfrom, NULL);
059ec3d9 1977 HDEBUG(D_acl) debug_printf("----------- end verify ------------\n");
8e669ac1 1978
059ec3d9 1979 *log_msgptr = addr2.message;
8e669ac1 1980 *user_msgptr = (addr2.user_message != NULL)?
6729cf78 1981 addr2.user_message : addr2.message;
059ec3d9
PH
1982 *basic_errno = addr2.basic_errno;
1983
1984 /* Make $address_data visible */
1985 deliver_address_data = addr2.p.address_data;
1986 }
1987
1988/* We have a result from the relevant test. Handle defer overrides first. */
1989
1990if (rc == DEFER && (defer_ok ||
1991 (callout_defer_ok && *basic_errno == ERRNO_CALLOUTDEFER)))
1992 {
1993 HDEBUG(D_acl) debug_printf("verify defer overridden by %s\n",
1994 defer_ok? "defer_ok" : "callout_defer_ok");
1995 rc = OK;
1996 }
1997
1998/* If we've failed a sender, set up a recipient message, and point
1999sender_verified_failed to the address item that actually failed. */
2000
2001if (rc != OK && verify_sender_address != NULL)
2002 {
2003 if (rc != DEFER)
2004 {
2005 *log_msgptr = *user_msgptr = US"Sender verify failed";
2006 }
2007 else if (*basic_errno != ERRNO_CALLOUTDEFER)
2008 {
2009 *log_msgptr = *user_msgptr = US"Could not complete sender verify";
2010 }
2011 else
2012 {
2013 *log_msgptr = US"Could not complete sender verify callout";
2014 *user_msgptr = smtp_return_error_details? sender_vaddr->user_message :
2015 *log_msgptr;
2016 }
2017
2018 sender_verified_failed = sender_vaddr;
2019 }
2020
2021/* Verifying an address messes up the values of $domain and $local_part,
2022so reset them before returning if this is a RCPT ACL. */
2023
2024if (addr != NULL)
2025 {
2026 deliver_domain = addr->domain;
2027 deliver_localpart = addr->local_part;
2028 }
2029return rc;
2030
2031/* Syntax errors in the verify argument come here. */
2032
2033BAD_VERIFY:
2034*log_msgptr = string_sprintf("expected \"sender[=address]\", \"recipient\", "
596875b3
PH
2035 "\"helo\", \"header_syntax\", \"header_sender\" or "
2036 "\"reverse_host_lookup\" at start of ACL condition "
059ec3d9
PH
2037 "\"verify %s\"", arg);
2038return ERROR;
596875b3
PH
2039
2040/* Options supplied when not allowed come here */
2041
2042NO_OPTIONS:
2043*log_msgptr = string_sprintf("unexpected '/' found in \"%s\" "
2044 "(this verify item has no options)", arg);
2045return ERROR;
1c41c9cc
PH
2046
2047/* Calls in the wrong ACL come here */
2048
2049WRONG_ACL:
2050*log_msgptr = string_sprintf("cannot check header contents in ACL for %s "
2051 "(only possible in ACL for DATA)", acl_wherenames[where]);
2052return ERROR;
059ec3d9
PH
2053}
2054
2055
2056
2057
2058/*************************************************
2059* Check argument for control= modifier *
2060*************************************************/
2061
2062/* Called from acl_check_condition() below
2063
2064Arguments:
2065 arg the argument string for control=
2066 pptr set to point to the terminating character
2067 where which ACL we are in
2068 log_msgptr for error messages
2069
2070Returns: CONTROL_xxx value
2071*/
2072
2073static int
2074decode_control(uschar *arg, uschar **pptr, int where, uschar **log_msgptr)
2075{
2076int len;
2077control_def *d;
2078
2079for (d = controls_list;
2080 d < controls_list + sizeof(controls_list)/sizeof(control_def);
2081 d++)
2082 {
2083 len = Ustrlen(d->name);
2084 if (Ustrncmp(d->name, arg, len) == 0) break;
2085 }
2086
2087if (d >= controls_list + sizeof(controls_list)/sizeof(control_def) ||
2088 (arg[len] != 0 && (!d->has_option || arg[len] != '/')))
2089 {
2090 *log_msgptr = string_sprintf("syntax error in \"control=%s\"", arg);
2091 return CONTROL_ERROR;
2092 }
2093
059ec3d9
PH
2094*pptr = arg + len;
2095return d->value;
2096}
2097
2098
2099
870f6ba8
TF
2100/*************************************************
2101* Handle rate limiting *
2102*************************************************/
2103
2104/* Called by acl_check_condition() below to calculate the result
2105of the ACL ratelimit condition.
2106
2107Note that the return value might be slightly unexpected: if the
2108sender's rate is above the limit then the result is OK. This is
2109similar to the dnslists condition, and is so that you can write
2110ACL clauses like: defer ratelimit = 15 / 1h
2111
2112Arguments:
2113 arg the option string for ratelimit=
90fc3069 2114 where ACL_WHERE_xxxx indicating which ACL this is
870f6ba8
TF
2115 log_msgptr for error messages
2116
2117Returns: OK - Sender's rate is above limit
2118 FAIL - Sender's rate is below limit
2119 DEFER - Problem opening ratelimit database
2120 ERROR - Syntax error in options.
2121*/
2122
2123static int
90fc3069 2124acl_ratelimit(uschar *arg, int where, uschar **log_msgptr)
870f6ba8
TF
2125{
2126double limit, period;
f3dcf4a2 2127uschar *ss, *key;
870f6ba8
TF
2128int sep = '/';
2129BOOL have_key = FALSE, leaky = FALSE, strict = FALSE;
2130BOOL per_byte = FALSE, per_cmd = FALSE, per_conn = FALSE, per_mail = FALSE;
2131int old_pool, rc;
2132tree_node **anchor, *t;
2133open_db dbblock, *dbm;
2134dbdata_ratelimit *dbd;
2135struct timeval tv;
2136
2137/* Parse the first two options and record their values in expansion
2138variables. These variables allow the configuration to have informative
2139error messages based on rate limits obtained from a table lookup. */
2140
2141/* First is the maximum number of messages per period and maximum burst
2142size, which must be greater than or equal to zero. Zero is useful for
2143rate measurement as opposed to rate limiting. */
2144
2145sender_rate_limit = string_nextinlist(&arg, &sep, NULL, 0);
2146if (sender_rate_limit == NULL)
2147 limit = -1.0;
2148else
2149 {
2150 limit = Ustrtod(sender_rate_limit, &ss);
2151 if (tolower(*ss) == 'k') { limit *= 1024.0; ss++; }
2152 else if (tolower(*ss) == 'm') { limit *= 1024.0*1024.0; ss++; }
2153 else if (tolower(*ss) == 'g') { limit *= 1024.0*1024.0*1024.0; ss++; }
2154 }
2155if (limit < 0.0 || *ss != 0)
2156 {
2157 *log_msgptr = string_sprintf("syntax error in argument for "
2158 "\"ratelimit\" condition: \"%s\" is not a positive number",
2159 sender_rate_limit);
2160 return ERROR;
2161 }
2162
f3dcf4a2
TF
2163/* We use the rest of the argument list following the limit as the
2164lookup key, because it doesn't make sense to use the same stored data
2165if the period or options are different. */
2166
2167key = arg;
2168
870f6ba8
TF
2169/* Second is the rate measurement period and exponential smoothing time
2170constant. This must be strictly greater than zero, because zero leads to
2171run-time division errors. */
2172
2173sender_rate_period = string_nextinlist(&arg, &sep, NULL, 0);
2174if (sender_rate_period == NULL) period = -1.0;
2175else period = readconf_readtime(sender_rate_period, 0, FALSE);
2176if (period <= 0.0)
2177 {
2178 *log_msgptr = string_sprintf("syntax error in argument for "
2179 "\"ratelimit\" condition: \"%s\" is not a time value",
2180 sender_rate_period);
2181 return ERROR;
2182 }
2183
2184/* Parse the other options. Should we check if the per_* options are being
2185used in ACLs where they don't make sense, e.g. per_mail in the connect ACL? */
2186
2187while ((ss = string_nextinlist(&arg, &sep, big_buffer, big_buffer_size))
2188 != NULL)
2189 {
2190 if (strcmpic(ss, US"leaky") == 0) leaky = TRUE;
2191 else if (strcmpic(ss, US"strict") == 0) strict = TRUE;
2192 else if (strcmpic(ss, US"per_byte") == 0) per_byte = TRUE;
2193 else if (strcmpic(ss, US"per_cmd") == 0) per_cmd = TRUE;
2194 else if (strcmpic(ss, US"per_conn") == 0) per_conn = TRUE;
2195 else if (strcmpic(ss, US"per_mail") == 0) per_mail = TRUE;
2196 else if (strcmpic(ss, US"per_rcpt") == 0) per_cmd = TRUE; /* alias */
2197 else have_key = TRUE;
2198 }
2199if (leaky + strict > 1 || per_byte + per_cmd + per_conn + per_mail > 1)
2200 {
2201 *log_msgptr = US"conflicting options for \"ratelimit\" condition";
2202 return ERROR;
2203 }
2204
2205/* Default option values */
2206if (!strict) leaky = TRUE;
2207if (!per_byte && !per_cmd && !per_conn) per_mail = TRUE;
2208
f3dcf4a2 2209/* If there is no explicit key, use the sender_host_address. If there is no
870f6ba8
TF
2210sender_host_address (e.g. -bs or acl_not_smtp) then we simply omit it. */
2211
2212if (!have_key && sender_host_address != NULL)
2213 key = string_sprintf("%s / %s", key, sender_host_address);
2214
2215HDEBUG(D_acl) debug_printf("ratelimit condition limit=%.0f period=%.0f key=%s\n",
2216 limit, period, key);
2217
fe0dab11 2218/* See if we have already computed the rate by looking in the relevant tree. For
870f6ba8
TF
2219per-connection rate limiting, store tree nodes and dbdata in the permanent pool
2220so that they survive across resets. */
2221
2222anchor = NULL;
2223old_pool = store_pool;
2224
2225if (per_conn)
2226 {
2227 anchor = &ratelimiters_conn;
2228 store_pool = POOL_PERM;
2229 }
fe0dab11 2230else if (per_mail || per_byte)
870f6ba8 2231 anchor = &ratelimiters_mail;
fe0dab11
TF
2232else if (per_cmd)
2233 anchor = &ratelimiters_cmd;
870f6ba8
TF
2234
2235if (anchor != NULL && (t = tree_search(*anchor, key)) != NULL)
2236 {
2237 dbd = t->data.ptr;
2238 /* The following few lines duplicate some of the code below. */
3348576f
TF
2239 if (dbd->rate < limit) rc = FAIL;
2240 else rc = OK;
870f6ba8
TF
2241 store_pool = old_pool;
2242 sender_rate = string_sprintf("%.1f", dbd->rate);
2243 HDEBUG(D_acl)
2244 debug_printf("ratelimit found pre-computed rate %s\n", sender_rate);
2245 return rc;
2246 }
2247
2248/* We aren't using a pre-computed rate, so get a previously recorded
2249rate from the database, update it, and write it back. If there's no
2250previous rate for this key, create one. */
2251
2252dbm = dbfn_open(US"ratelimit", O_RDWR, &dbblock, TRUE);
2253if (dbm == NULL)
2254 {
2255 store_pool = old_pool;
2256 sender_rate = NULL;
2257 HDEBUG(D_acl) debug_printf("ratelimit database not available\n");
2258 *log_msgptr = US"ratelimit database not available";
2259 return DEFER;
2260 }
2261dbd = dbfn_read(dbm, key);
2262
2263gettimeofday(&tv, NULL);
2264
2265if (dbd == NULL)
2266 {
2267 HDEBUG(D_acl) debug_printf("ratelimit initializing new key's data\n");
2268 dbd = store_get(sizeof(dbdata_ratelimit));
2269 dbd->time_stamp = tv.tv_sec;
2270 dbd->time_usec = tv.tv_usec;
2271 dbd->rate = 0.0;
2272 }
2273else
2274 {
2275 /* The smoothed rate is computed using an exponentially weighted moving
2276 average adjusted for variable sampling intervals. The standard EWMA for
2277 a fixed sampling interval is: f'(t) = (1 - a) * f(t) + a * f'(t - 1)
2278 where f() is the measured value and f'() is the smoothed value.
2279
2280 Old data decays out of the smoothed value exponentially, such that data n
2281 samples old is multiplied by a^n. The exponential decay time constant p
2282 is defined such that data p samples old is multiplied by 1/e, which means
2283 that a = exp(-1/p). We can maintain the same time constant for a variable
2284 sampling interval i by using a = exp(-i/p).
2285
2286 The rate we are measuring is messages per period, suitable for directly
2287 comparing with the limit. The average rate between now and the previous
2288 message is period / interval, which we feed into the EWMA as the sample.
2289
2290 It turns out that the number of messages required for the smoothed rate
2291 to reach the limit when they are sent in a burst is equal to the limit.
2292 This can be seen by analysing the value of the smoothed rate after N
2293 messages sent at even intervals. Let k = (1 - a) * p/i
2294
2295 rate_1 = (1 - a) * p/i + a * rate_0
2296 = k + a * rate_0
2297 rate_2 = k + a * rate_1
2298 = k + a * k + a^2 * rate_0
2299 rate_3 = k + a * k + a^2 * k + a^3 * rate_0
2300 rate_N = rate_0 * a^N + k * SUM(x=0..N-1)(a^x)
2301 = rate_0 * a^N + k * (1 - a^N) / (1 - a)
2302 = rate_0 * a^N + p/i * (1 - a^N)
2303
2304 When N is large, a^N -> 0 so rate_N -> p/i as desired.
2305
2306 rate_N = p/i + (rate_0 - p/i) * a^N
2307 a^N = (rate_N - p/i) / (rate_0 - p/i)
2308 N * -i/p = log((rate_N - p/i) / (rate_0 - p/i))
2309 N = p/i * log((rate_0 - p/i) / (rate_N - p/i))
2310
2311 Numerical analysis of the above equation, setting the computed rate to
2312 increase from rate_0 = 0 to rate_N = limit, shows that for large sending
2313 rates, p/i, the number of messages N = limit. So limit serves as both the
2314 maximum rate measured in messages per period, and the maximum number of
2315 messages that can be sent in a fast burst. */
2316
2317 double this_time = (double)tv.tv_sec
2318 + (double)tv.tv_usec / 1000000.0;
2319 double prev_time = (double)dbd->time_stamp
2320 + (double)dbd->time_usec / 1000000.0;
870f6ba8
TF
2321
2322 /* We must avoid division by zero, and deal gracefully with the clock going
2323 backwards. If we blunder ahead when time is in reverse then the computed
e5d5a95f 2324 rate will be bogus. To be safe we clamp interval to a very small number. */
870f6ba8 2325
e5d5a95f
TF
2326 double interval = this_time - prev_time <= 0.0 ? 1e-9
2327 : this_time - prev_time;
2328
2329 double i_over_p = interval / period;
2330 double a = exp(-i_over_p);
870f6ba8
TF
2331
2332 dbd->time_stamp = tv.tv_sec;
2333 dbd->time_usec = tv.tv_usec;
2334
2335 /* If we are measuring the rate in bytes per period, multiply the
2336 measured rate by the message size. If we don't know the message size
2337 then it's safe to just use a value of zero and let the recorded rate
2338 decay as if nothing happened. */
2339
2340 if (per_byte)
2341 dbd->rate = (message_size < 0 ? 0.0 : (double)message_size)
2342 * (1 - a) / i_over_p + a * dbd->rate;
90fc3069
TF
2343 else if (per_cmd && where == ACL_WHERE_NOTSMTP)
2344 dbd->rate = (double)recipients_count
2345 * (1 - a) / i_over_p + a * dbd->rate;
870f6ba8
TF
2346 else
2347 dbd->rate = (1 - a) / i_over_p + a * dbd->rate;
2348 }
2349
3348576f
TF
2350/* Clients sending at the limit are considered to be over the limit. This
2351matters for edge cases such the first message sent by a client (which gets
2352the initial rate of 0.0) when the rate limit is zero (i.e. the client should
2353be completely blocked). */
2354
2355if (dbd->rate < limit) rc = FAIL;
2356 else rc = OK;
870f6ba8
TF
2357
2358/* Update the state if the rate is low or if we are being strict. If we
2359are in leaky mode and the sender's rate is too high, we do not update
2360the recorded rate in order to avoid an over-aggressive sender's retry
2361rate preventing them from getting any email through. */
2362
2363if (rc == FAIL || !leaky)
2364 dbfn_write(dbm, key, dbd, sizeof(dbdata_ratelimit));
2365dbfn_close(dbm);
2366
2367/* Store the result in the tree for future reference, if necessary. */
2368
2369if (anchor != NULL)
2370 {
2371 t = store_get(sizeof(tree_node) + Ustrlen(key));
2372 t->data.ptr = dbd;
2373 Ustrcpy(t->name, key);
2374 (void)tree_insertnode(anchor, t);
2375 }
2376
2377/* We create the formatted version of the sender's rate very late in
2378order to ensure that it is done using the correct storage pool. */
2379
2380store_pool = old_pool;
2381sender_rate = string_sprintf("%.1f", dbd->rate);
2382
2383HDEBUG(D_acl)
2384 debug_printf("ratelimit computed rate %s\n", sender_rate);
2385
2386return rc;
2387}
2388
2389
2390
059ec3d9
PH
2391/*************************************************
2392* Handle conditions/modifiers on an ACL item *
2393*************************************************/
2394
2395/* Called from acl_check() below.
2396
2397Arguments:
2398 verb ACL verb
2399 cb ACL condition block - if NULL, result is OK
2400 where where called from
2401 addr the address being checked for RCPT, or NULL
2402 level the nesting level
2403 epp pointer to pass back TRUE if "endpass" encountered
2404 (applies only to "accept" and "discard")
2405 user_msgptr user message pointer
2406 log_msgptr log message pointer
2407 basic_errno pointer to where to put verify error
2408
2409Returns: OK - all conditions are met
2410 DISCARD - an "acl" condition returned DISCARD - only allowed
2411 for "accept" or "discard" verbs
2412 FAIL - at least one condition fails
2413 FAIL_DROP - an "acl" condition returned FAIL_DROP
2414 DEFER - can't tell at the moment (typically, lookup defer,
2415 but can be temporary callout problem)
2416 ERROR - ERROR from nested ACL or expansion failure or other
2417 error
2418*/
2419
2420static int
2421acl_check_condition(int verb, acl_condition_block *cb, int where,
2422 address_item *addr, int level, BOOL *epp, uschar **user_msgptr,
2423 uschar **log_msgptr, int *basic_errno)
2424{
2425uschar *user_message = NULL;
2426uschar *log_message = NULL;
91ecef39 2427uschar *p = NULL;
059ec3d9 2428int rc = OK;
8523533c
TK
2429#ifdef WITH_CONTENT_SCAN
2430int sep = '/';
2431#endif
059ec3d9
PH
2432
2433for (; cb != NULL; cb = cb->next)
2434 {
2435 uschar *arg;
8e669ac1 2436 int control_type;
059ec3d9
PH
2437
2438 /* The message and log_message items set up messages to be used in
2439 case of rejection. They are expanded later. */
2440
2441 if (cb->type == ACLC_MESSAGE)
2442 {
2443 user_message = cb->arg;
2444 continue;
2445 }
2446
2447 if (cb->type == ACLC_LOG_MESSAGE)
2448 {
2449 log_message = cb->arg;
2450 continue;
2451 }
2452
2453 /* The endpass "condition" just sets a flag to show it occurred. This is
2454 checked at compile time to be on an "accept" or "discard" item. */
2455
2456 if (cb->type == ACLC_ENDPASS)
2457 {
2458 *epp = TRUE;
2459 continue;
2460 }
2461
2462 /* For other conditions and modifiers, the argument is expanded now for some
2463 of them, but not for all, because expansion happens down in some lower level
2464 checking functions in some cases. */
2465
2466 if (cond_expand_at_top[cb->type])
2467 {
2468 arg = expand_string(cb->arg);
2469 if (arg == NULL)
2470 {
2471 if (expand_string_forcedfail) continue;
2472 *log_msgptr = string_sprintf("failed to expand ACL string \"%s\": %s",
2473 cb->arg, expand_string_message);
2474 return search_find_defer? DEFER : ERROR;
2475 }
2476 }
2477 else arg = cb->arg;
2478
2479 /* Show condition, and expanded condition if it's different */
2480
2481 HDEBUG(D_acl)
2482 {
2483 int lhswidth = 0;
2484 debug_printf("check %s%s %n",
2485 (!cond_modifiers[cb->type] && cb->u.negated)? "!":"",
2486 conditions[cb->type], &lhswidth);
2487
2488 if (cb->type == ACLC_SET)
2489 {
38a0a95f
PH
2490 debug_printf("acl_%s ", cb->u.varname);
2491 lhswidth += 5 + Ustrlen(cb->u.varname);
059ec3d9
PH
2492 }
2493
2494 debug_printf("= %s\n", cb->arg);
2495
2496 if (arg != cb->arg)
2497 debug_printf("%.*s= %s\n", lhswidth,
2498 US" ", CS arg);
2499 }
2500
2501 /* Check that this condition makes sense at this time */
2502
2503 if ((cond_forbids[cb->type] & (1 << where)) != 0)
2504 {
2505 *log_msgptr = string_sprintf("cannot %s %s condition in %s ACL",
2506 cond_modifiers[cb->type]? "use" : "test",
2507 conditions[cb->type], acl_wherenames[where]);
2508 return ERROR;
2509 }
2510
2511 /* Run the appropriate test for each condition, or take the appropriate
2512 action for the remaining modifiers. */
2513
2514 switch(cb->type)
2515 {
71fafd95
PH
2516 case ACLC_ADD_HEADER:
2517 setup_header(arg);
2518 break;
2519
059ec3d9
PH
2520 /* A nested ACL that returns "discard" makes sense only for an "accept" or
2521 "discard" verb. */
71fafd95 2522
059ec3d9
PH
2523 case ACLC_ACL:
2524 rc = acl_check_internal(where, addr, arg, level+1, user_msgptr, log_msgptr);
2525 if (rc == DISCARD && verb != ACL_ACCEPT && verb != ACL_DISCARD)
2526 {
2527 *log_msgptr = string_sprintf("nested ACL returned \"discard\" for "
2528 "\"%s\" command (only allowed with \"accept\" or \"discard\")",
2529 verbs[verb]);
2530 return ERROR;
2531 }
2532 break;
2533
2534 case ACLC_AUTHENTICATED:
2535 rc = (sender_host_authenticated == NULL)? FAIL :
2536 match_isinlist(sender_host_authenticated, &arg, 0, NULL, NULL, MCL_STRING,
2537 TRUE, NULL);
2538 break;
2539
71fafd95 2540 #ifdef EXPERIMENTAL_BRIGHTMAIL
8523533c
TK
2541 case ACLC_BMI_OPTIN:
2542 {
2543 int old_pool = store_pool;
2544 store_pool = POOL_PERM;
2545 bmi_current_optin = string_copy(arg);
2546 store_pool = old_pool;
2547 }
2548 break;
71fafd95 2549 #endif
8523533c 2550
059ec3d9
PH
2551 case ACLC_CONDITION:
2552 if (Ustrspn(arg, "0123456789") == Ustrlen(arg)) /* Digits, or empty */
2553 rc = (Uatoi(arg) == 0)? FAIL : OK;
2554 else
2555 rc = (strcmpic(arg, US"no") == 0 ||
2556 strcmpic(arg, US"false") == 0)? FAIL :
2557 (strcmpic(arg, US"yes") == 0 ||
2558 strcmpic(arg, US"true") == 0)? OK : DEFER;
2559 if (rc == DEFER)
2560 *log_msgptr = string_sprintf("invalid \"condition\" value \"%s\"", arg);
2561 break;
2562
c3611384
PH
2563 case ACLC_CONTINUE: /* Always succeeds */
2564 break;
2565
059ec3d9 2566 case ACLC_CONTROL:
c5fcb476
PH
2567 control_type = decode_control(arg, &p, where, log_msgptr);
2568
8523533c 2569 /* Check if this control makes sense at this time */
c5fcb476
PH
2570
2571 if ((control_forbids[control_type] & (1 << where)) != 0)
2572 {
2573 *log_msgptr = string_sprintf("cannot use \"control=%s\" in %s ACL",
2574 controls[control_type], acl_wherenames[where]);
2575 return ERROR;
8e669ac1 2576 }
c5fcb476
PH
2577
2578 switch(control_type)
059ec3d9 2579 {
c46782ef
PH
2580 case CONTROL_AUTH_UNADVERTISED:
2581 allow_auth_unadvertised = TRUE;
2582 break;
2583
2584 #ifdef EXPERIMENTAL_BRIGHTMAIL
8523533c
TK
2585 case CONTROL_BMI_RUN:
2586 bmi_run = 1;
2587 break;
c46782ef
PH
2588 #endif
2589
2590 #ifdef EXPERIMENTAL_DOMAINKEYS
fb2274d4
TK
2591 case CONTROL_DK_VERIFY:
2592 dk_do_verify = 1;
2593 break;
c46782ef
PH
2594 #endif
2595
059ec3d9
PH
2596 case CONTROL_ERROR:
2597 return ERROR;
2598
2599 case CONTROL_CASEFUL_LOCAL_PART:
2600 deliver_localpart = addr->cc_local_part;
2601 break;
2602
2603 case CONTROL_CASELOWER_LOCAL_PART:
2604 deliver_localpart = addr->lc_local_part;
2605 break;
2606
2607 case CONTROL_ENFORCE_SYNC:
2608 smtp_enforce_sync = TRUE;
2609 break;
2610
2611 case CONTROL_NO_ENFORCE_SYNC:
2612 smtp_enforce_sync = FALSE;
2613 break;
2614
c46782ef 2615 #ifdef WITH_CONTENT_SCAN
8523533c
TK
2616 case CONTROL_NO_MBOX_UNSPOOL:
2617 no_mbox_unspool = TRUE;
2618 break;
c46782ef 2619 #endif
8523533c 2620
059ec3d9
PH
2621 case CONTROL_NO_MULTILINE:
2622 no_multiline_responses = TRUE;
2623 break;
2624
cf8b11a5
PH
2625 case CONTROL_NO_PIPELINING:
2626 pipelining_enable = FALSE;
2627 break;
2628
047bdd8c
PH
2629 case CONTROL_NO_DELAY_FLUSH:
2630 disable_delay_flush = TRUE;
2631 break;
2632
4c590bd1
PH
2633 case CONTROL_NO_CALLOUT_FLUSH:
2634 disable_callout_flush = TRUE;
2635 break;
2636
29aba418 2637 case CONTROL_FAKEDEFER:
8523533c 2638 case CONTROL_FAKEREJECT:
29aba418 2639 fake_response = (control_type == CONTROL_FAKEDEFER) ? DEFER : FAIL;
8523533c 2640 if (*p == '/')
8e669ac1 2641 {
8523533c 2642 uschar *pp = p + 1;
8e669ac1 2643 while (*pp != 0) pp++;
29aba418 2644 fake_response_text = expand_string(string_copyn(p+1, pp-p-1));
8523533c
TK
2645 p = pp;
2646 }
2647 else
2648 {
2649 /* Explicitly reset to default string */
29aba418 2650 fake_response_text = US"Your message has been rejected but is being kept for evaluation.\nIf it was a legitimate message, it may still be delivered to the target recipient(s).";
8523533c
TK
2651 }
2652 break;
8523533c 2653
059ec3d9
PH
2654 case CONTROL_FREEZE:
2655 deliver_freeze = TRUE;
2656 deliver_frozen_at = time(NULL);
6a3f1455
PH
2657 freeze_tell = freeze_tell_config; /* Reset to configured value */
2658 if (Ustrncmp(p, "/no_tell", 8) == 0)
2659 {
2660 p += 8;
2661 freeze_tell = NULL;
2662 }
2663 if (*p != 0)
2664 {
2665 *log_msgptr = string_sprintf("syntax error in \"control=%s\"", arg);
2666 return ERROR;
2667 }
059ec3d9
PH
2668 break;
2669
2670 case CONTROL_QUEUE_ONLY:
2671 queue_only_policy = TRUE;
2672 break;
2673
2674 case CONTROL_SUBMISSION:
87ba3f5f 2675 originator_name = US"";
059ec3d9 2676 submission_mode = TRUE;
69358f02 2677 while (*p == '/')
8e669ac1 2678 {
69358f02
PH
2679 if (Ustrncmp(p, "/sender_retain", 14) == 0)
2680 {
2681 p += 14;
2682 active_local_sender_retain = TRUE;
8e669ac1
PH
2683 active_local_from_check = FALSE;
2684 }
69358f02
PH
2685 else if (Ustrncmp(p, "/domain=", 8) == 0)
2686 {
2687 uschar *pp = p + 8;
8e669ac1 2688 while (*pp != 0 && *pp != '/') pp++;
87ba3f5f
PH
2689 submission_domain = string_copyn(p+8, pp-p-8);
2690 p = pp;
2691 }
8857ccfd
PH
2692 /* The name= option must be last, because it swallows the rest of
2693 the string. */
87ba3f5f
PH
2694 else if (Ustrncmp(p, "/name=", 6) == 0)
2695 {
2696 uschar *pp = p + 6;
8857ccfd 2697 while (*pp != 0) pp++;
2fe1a124 2698 submission_name = string_copy(parse_fix_phrase(p+6, pp-p-6,
87ba3f5f 2699 big_buffer, big_buffer_size));
8e669ac1 2700 p = pp;
69358f02 2701 }
8e669ac1
PH
2702 else break;
2703 }
69358f02 2704 if (*p != 0)
059ec3d9 2705 {
69358f02 2706 *log_msgptr = string_sprintf("syntax error in \"control=%s\"", arg);
059ec3d9
PH
2707 return ERROR;
2708 }
2709 break;
8800895a
PH
2710
2711 case CONTROL_SUPPRESS_LOCAL_FIXUPS:
2712 suppress_local_fixups = TRUE;
2713 break;
059ec3d9
PH
2714 }
2715 break;
2716
71fafd95 2717 #ifdef WITH_CONTENT_SCAN
8523533c
TK
2718 case ACLC_DECODE:
2719 rc = mime_decode(&arg);
2720 break;
71fafd95 2721 #endif
8523533c 2722
059ec3d9
PH
2723 case ACLC_DELAY:
2724 {
2725 int delay = readconf_readtime(arg, 0, FALSE);
2726 if (delay < 0)
2727 {
2728 *log_msgptr = string_sprintf("syntax error in argument for \"delay\" "
2729 "modifier: \"%s\" is not a time value", arg);
2730 return ERROR;
2731 }
2732 else
2733 {
2734 HDEBUG(D_acl) debug_printf("delay modifier requests %d-second delay\n",
2735 delay);
2736 if (host_checking)
2737 {
2738 HDEBUG(D_acl)
2739 debug_printf("delay skipped in -bh checking mode\n");
2740 }
010c2d14
PH
2741
2742 /* It appears to be impossible to detect that a TCP/IP connection has
2743 gone away without reading from it. This means that we cannot shorten
2744 the delay below if the client goes away, because we cannot discover
2745 that the client has closed its end of the connection. (The connection
2746 is actually in a half-closed state, waiting for the server to close its
2747 end.) It would be nice to be able to detect this state, so that the
2748 Exim process is not held up unnecessarily. However, it seems that we
2749 can't. The poll() function does not do the right thing, and in any case
2750 it is not always available.
2751
047bdd8c 2752 NOTE 1: If ever this state of affairs changes, remember that we may be
010c2d14 2753 dealing with stdin/stdout here, in addition to TCP/IP connections.
047bdd8c
PH
2754 Also, delays may be specified for non-SMTP input, where smtp_out and
2755 smtp_in will be NULL. Whatever is done must work in all cases.
2756
2757 NOTE 2: The added feature of flushing the output before a delay must
2758 apply only to SMTP input. Hence the test for smtp_out being non-NULL.
2759 */
010c2d14 2760
8e669ac1 2761 else
86b8287f 2762 {
14f4a80d 2763 if (smtp_out != NULL && !disable_delay_flush) mac_smtp_fflush();
86b8287f 2764 while (delay > 0) delay = sleep(delay);
8e669ac1 2765 }
059ec3d9
PH
2766 }
2767 }
2768 break;
2769
71fafd95 2770 #ifdef WITH_OLD_DEMIME
8523533c
TK
2771 case ACLC_DEMIME:
2772 rc = demime(&arg);
2773 break;
71fafd95 2774 #endif
8523533c 2775
71fafd95
PH
2776 #ifdef EXPERIMENTAL_DOMAINKEYS
2777 case ACLC_DK_DOMAIN_SOURCE:
fb2274d4
TK
2778 if (dk_verify_block == NULL) { rc = FAIL; break; };
2779 /* check header source of domain against given string */
2780 switch (dk_verify_block->address_source) {
2781 case DK_EXIM_ADDRESS_FROM_FROM:
2782 rc = match_isinlist(US"from", &arg, 0, NULL,
2783 NULL, MCL_STRING, TRUE, NULL);
2784 break;
2785 case DK_EXIM_ADDRESS_FROM_SENDER:
2786 rc = match_isinlist(US"sender", &arg, 0, NULL,
2787 NULL, MCL_STRING, TRUE, NULL);
2788 break;
2789 case DK_EXIM_ADDRESS_NONE:
2790 rc = match_isinlist(US"none", &arg, 0, NULL,
2791 NULL, MCL_STRING, TRUE, NULL);
2792 break;
71fafd95
PH
2793 }
2794 break;
2795
2796 case ACLC_DK_POLICY:
fb2274d4
TK
2797 if (dk_verify_block == NULL) { rc = FAIL; break; };
2798 /* check policy against given string, default FAIL */
2799 rc = FAIL;
2800 if (dk_verify_block->signsall)
2801 rc = match_isinlist(US"signsall", &arg, 0, NULL,
2802 NULL, MCL_STRING, TRUE, NULL);
2803 if (dk_verify_block->testing)
2804 rc = match_isinlist(US"testing", &arg, 0, NULL,
2805 NULL, MCL_STRING, TRUE, NULL);
71fafd95
PH
2806 break;
2807
2808 case ACLC_DK_SENDER_DOMAINS:
fb2274d4
TK
2809 if (dk_verify_block == NULL) { rc = FAIL; break; };
2810 if (dk_verify_block->domain != NULL)
2811 rc = match_isinlist(dk_verify_block->domain, &arg, 0, &domainlist_anchor,
2812 NULL, MCL_DOMAIN, TRUE, NULL);
2813 else rc = FAIL;
71fafd95
PH
2814 break;
2815
2816 case ACLC_DK_SENDER_LOCAL_PARTS:
fb2274d4
TK
2817 if (dk_verify_block == NULL) { rc = FAIL; break; };
2818 if (dk_verify_block->local_part != NULL)
2819 rc = match_isinlist(dk_verify_block->local_part, &arg, 0, &localpartlist_anchor,
2820 NULL, MCL_LOCALPART, TRUE, NULL);
2821 else rc = FAIL;
71fafd95
PH
2822 break;
2823
2824 case ACLC_DK_SENDERS:
fb2274d4
TK
2825 if (dk_verify_block == NULL) { rc = FAIL; break; };
2826 if (dk_verify_block->address != NULL)
2827 rc = match_address_list(dk_verify_block->address, TRUE, TRUE, &arg, NULL, -1, 0, NULL);
2828 else rc = FAIL;
71fafd95
PH
2829 break;
2830
2831 case ACLC_DK_STATUS:
fb2274d4
TK
2832 if (dk_verify_block == NULL) { rc = FAIL; break; };
2833 if (dk_verify_block->result > 0) {
2834 switch(dk_verify_block->result) {
2835 case DK_EXIM_RESULT_BAD_FORMAT:
2836 rc = match_isinlist(US"bad format", &arg, 0, NULL,
2837 NULL, MCL_STRING, TRUE, NULL);
2838 break;
2839 case DK_EXIM_RESULT_NO_KEY:
2840 rc = match_isinlist(US"no key", &arg, 0, NULL,
2841 NULL, MCL_STRING, TRUE, NULL);
2842 break;
2843 case DK_EXIM_RESULT_NO_SIGNATURE:
2844 rc = match_isinlist(US"no signature", &arg, 0, NULL,
2845 NULL, MCL_STRING, TRUE, NULL);
2846 break;
2847 case DK_EXIM_RESULT_REVOKED:
2848 rc = match_isinlist(US"revoked", &arg, 0, NULL,
2849 NULL, MCL_STRING, TRUE, NULL);
2850 break;
2851 case DK_EXIM_RESULT_NON_PARTICIPANT:
2852 rc = match_isinlist(US"non-participant", &arg, 0, NULL,
2853 NULL, MCL_STRING, TRUE, NULL);
2854 break;
2855 case DK_EXIM_RESULT_GOOD:
2856 rc = match_isinlist(US"good", &arg, 0, NULL,
2857 NULL, MCL_STRING, TRUE, NULL);
2858 break;
2859 case DK_EXIM_RESULT_BAD:
2860 rc = match_isinlist(US"bad", &arg, 0, NULL,
2861 NULL, MCL_STRING, TRUE, NULL);
2862 break;
71fafd95 2863 }
fb2274d4 2864 }
71fafd95
PH
2865 break;
2866 #endif
fb2274d4 2867
059ec3d9
PH
2868 case ACLC_DNSLISTS:
2869 rc = verify_check_dnsbl(&arg);
2870 break;
2871
2872 case ACLC_DOMAINS:
2873 rc = match_isinlist(addr->domain, &arg, 0, &domainlist_anchor,
2874 addr->domain_cache, MCL_DOMAIN, TRUE, &deliver_domain_data);
2875 break;
2876
2877 /* The value in tls_cipher is the full cipher name, for example,
2878 TLSv1:DES-CBC3-SHA:168, whereas the values to test for are just the
2879 cipher names such as DES-CBC3-SHA. But program defensively. We don't know
2880 what may in practice come out of the SSL library - which at the time of
2881 writing is poorly documented. */
2882
2883 case ACLC_ENCRYPTED:
2884 if (tls_cipher == NULL) rc = FAIL; else
2885 {
2886 uschar *endcipher = NULL;
2887 uschar *cipher = Ustrchr(tls_cipher, ':');
2888 if (cipher == NULL) cipher = tls_cipher; else
2889 {
2890 endcipher = Ustrchr(++cipher, ':');
2891 if (endcipher != NULL) *endcipher = 0;
2892 }
2893 rc = match_isinlist(cipher, &arg, 0, NULL, NULL, MCL_STRING, TRUE, NULL);
2894 if (endcipher != NULL) *endcipher = ':';
2895 }
2896 break;
2897
2898 /* Use verify_check_this_host() instead of verify_check_host() so that
2899 we can pass over &host_data to catch any looked up data. Once it has been
2900 set, it retains its value so that it's still there if another ACL verb
2901 comes through here and uses the cache. However, we must put it into
2902 permanent store in case it is also expected to be used in a subsequent
2903 message in the same SMTP connection. */
2904
2905 case ACLC_HOSTS:
2906 rc = verify_check_this_host(&arg, sender_host_cache, NULL,
2907 (sender_host_address == NULL)? US"" : sender_host_address, &host_data);
2908 if (host_data != NULL) host_data = string_copy_malloc(host_data);
2909 break;
2910
2911 case ACLC_LOCAL_PARTS:
2912 rc = match_isinlist(addr->cc_local_part, &arg, 0,
2913 &localpartlist_anchor, addr->localpart_cache, MCL_LOCALPART, TRUE,
2914 &deliver_localpart_data);
2915 break;
2916
6ea85e9a
PH
2917 case ACLC_LOG_REJECT_TARGET:
2918 {
2919 int logbits = 0;
2920 int sep = 0;
2921 uschar *s = arg;
2922 uschar *ss;
2923 while ((ss = string_nextinlist(&s, &sep, big_buffer, big_buffer_size))
2924 != NULL)
2925 {
2926 if (Ustrcmp(ss, "main") == 0) logbits |= LOG_MAIN;
2927 else if (Ustrcmp(ss, "panic") == 0) logbits |= LOG_PANIC;
2928 else if (Ustrcmp(ss, "reject") == 0) logbits |= LOG_REJECT;
2929 else
2930 {
2931 logbits |= LOG_MAIN|LOG_REJECT;
2932 log_write(0, LOG_MAIN|LOG_PANIC, "unknown log name \"%s\" in "
2933 "\"log_reject_target\" in %s ACL", ss, acl_wherenames[where]);
2934 }
2935 }
2936 log_reject_target = logbits;
2937 }
2938 break;
2939
059ec3d9
PH
2940 case ACLC_LOGWRITE:
2941 {
2942 int logbits = 0;
2943 uschar *s = arg;
2944 if (*s == ':')
2945 {
2946 s++;
2947 while (*s != ':')
2948 {
2949 if (Ustrncmp(s, "main", 4) == 0)
2950 { logbits |= LOG_MAIN; s += 4; }
2951 else if (Ustrncmp(s, "panic", 5) == 0)
2952 { logbits |= LOG_PANIC; s += 5; }
2953 else if (Ustrncmp(s, "reject", 6) == 0)
2954 { logbits |= LOG_REJECT; s += 6; }
2955 else
2956 {
2957 logbits = LOG_MAIN|LOG_PANIC;
2958 s = string_sprintf(":unknown log name in \"%s\" in "
2959 "\"logwrite\" in %s ACL", arg, acl_wherenames[where]);
2960 }
2961 if (*s == ',') s++;
2962 }
2963 s++;
2964 }
2965 while (isspace(*s)) s++;
6ea85e9a
PH
2966
2967
059ec3d9
PH
2968 if (logbits == 0) logbits = LOG_MAIN;
2969 log_write(0, logbits, "%s", string_printing(s));
2970 }
2971 break;
8e669ac1 2972
71fafd95 2973 #ifdef WITH_CONTENT_SCAN
8523533c
TK
2974 case ACLC_MALWARE:
2975 {
6ea85e9a 2976 /* Separate the regular expression and any optional parameters. */
8523533c
TK
2977 uschar *ss = string_nextinlist(&arg, &sep, big_buffer, big_buffer_size);
2978 /* Run the malware backend. */
2979 rc = malware(&ss);
2980 /* Modify return code based upon the existance of options. */
2981 while ((ss = string_nextinlist(&arg, &sep, big_buffer, big_buffer_size))
2982 != NULL) {
2983 if (strcmpic(ss, US"defer_ok") == 0 && rc == DEFER)
2984 {
2985 /* FAIL so that the message is passed to the next ACL */
2986 rc = FAIL;
2987 }
2988 }
2989 }
2990 break;
2991
2992 case ACLC_MIME_REGEX:
71fafd95 2993 rc = mime_regex(&arg);
8523533c 2994 break;
71fafd95 2995 #endif
059ec3d9 2996
870f6ba8 2997 case ACLC_RATELIMIT:
90fc3069 2998 rc = acl_ratelimit(arg, where, log_msgptr);
870f6ba8
TF
2999 break;
3000
059ec3d9
PH
3001 case ACLC_RECIPIENTS:
3002 rc = match_address_list(addr->address, TRUE, TRUE, &arg, NULL, -1, 0,
3003 &recipient_data);
3004 break;
3005
71fafd95
PH
3006 #ifdef WITH_CONTENT_SCAN
3007 case ACLC_REGEX:
3008 rc = regex(&arg);
8523533c 3009 break;
71fafd95 3010 #endif
8523533c 3011
059ec3d9
PH
3012 case ACLC_SENDER_DOMAINS:
3013 {
3014 uschar *sdomain;
3015 sdomain = Ustrrchr(sender_address, '@');
3016 sdomain = (sdomain == NULL)? US"" : sdomain + 1;
3017 rc = match_isinlist(sdomain, &arg, 0, &domainlist_anchor,
3018 sender_domain_cache, MCL_DOMAIN, TRUE, NULL);
3019 }
3020 break;
3021
3022 case ACLC_SENDERS:
3023 rc = match_address_list(sender_address, TRUE, TRUE, &arg,
3024 sender_address_cache, -1, 0, &sender_data);
3025 break;
3026
3027 /* Connection variables must persist forever */
3028
3029 case ACLC_SET:
3030 {
3031 int old_pool = store_pool;
38a0a95f
PH
3032 if (cb->u.varname[0] == 'c') store_pool = POOL_PERM;
3033 acl_var_create(cb->u.varname)->data.ptr = string_copy(arg);
059ec3d9
PH
3034 store_pool = old_pool;
3035 }
3036 break;
3037
71fafd95 3038 #ifdef WITH_CONTENT_SCAN
8523533c
TK
3039 case ACLC_SPAM:
3040 {
3041 /* Seperate the regular expression and any optional parameters. */
3042 uschar *ss = string_nextinlist(&arg, &sep, big_buffer, big_buffer_size);
3043 /* Run the spam backend. */
3044 rc = spam(&ss);
3045 /* Modify return code based upon the existance of options. */
3046 while ((ss = string_nextinlist(&arg, &sep, big_buffer, big_buffer_size))
3047 != NULL) {
3048 if (strcmpic(ss, US"defer_ok") == 0 && rc == DEFER)
3049 {
3050 /* FAIL so that the message is passed to the next ACL */
3051 rc = FAIL;
3052 }
3053 }
3054 }
3055 break;
71fafd95 3056 #endif
8523533c 3057
71fafd95 3058 #ifdef EXPERIMENTAL_SPF
8523533c
TK
3059 case ACLC_SPF:
3060 rc = spf_process(&arg, sender_address);
3061 break;
71fafd95 3062 #endif
8523533c 3063
059ec3d9
PH
3064 /* If the verb is WARN, discard any user message from verification, because
3065 such messages are SMTP responses, not header additions. The latter come
475fe28a
PH
3066 only from explicit "message" modifiers. However, put the user message into
3067 $acl_verify_message so it can be used in subsequent conditions or modifiers
3068 (until something changes it). */
059ec3d9
PH
3069
3070 case ACLC_VERIFY:
3071 rc = acl_verify(where, addr, arg, user_msgptr, log_msgptr, basic_errno);
475fe28a 3072 acl_verify_message = *user_msgptr;
059ec3d9
PH
3073 if (verb == ACL_WARN) *user_msgptr = NULL;
3074 break;
3075
3076 default:
3077 log_write(0, LOG_MAIN|LOG_PANIC_DIE, "internal ACL error: unknown "
3078 "condition %d", cb->type);
3079 break;
3080 }
3081
3082 /* If a condition was negated, invert OK/FAIL. */
3083
3084 if (!cond_modifiers[cb->type] && cb->u.negated)
3085 {
3086 if (rc == OK) rc = FAIL;
3087 else if (rc == FAIL || rc == FAIL_DROP) rc = OK;
3088 }
3089
3090 if (rc != OK) break; /* Conditions loop */
3091 }
3092
3093
3094/* If the result is the one for which "message" and/or "log_message" are used,
4e88a19f
PH
3095handle the values of these modifiers. If there isn't a log message set, we make
3096it the same as the user message.
059ec3d9
PH
3097
3098"message" is a user message that will be included in an SMTP response. Unless
3099it is empty, it overrides any previously set user message.
3100
3101"log_message" is a non-user message, and it adds to any existing non-user
3102message that is already set.
3103
4e88a19f
PH
3104Most verbs have but a single return for which the messages are relevant, but
3105for "discard", it's useful to have the log message both when it succeeds and
3106when it fails. For "accept", the message is used in the OK case if there is no
3107"endpass", but (for backwards compatibility) in the FAIL case if "endpass" is
3108present. */
059ec3d9 3109
4e88a19f
PH
3110if (*epp && rc == OK) user_message = NULL;
3111
3112if (((1<<rc) & msgcond[verb]) != 0)
059ec3d9
PH
3113 {
3114 uschar *expmessage;
4e88a19f
PH
3115 uschar *old_user_msgptr = *user_msgptr;
3116 uschar *old_log_msgptr = (*log_msgptr != NULL)? *log_msgptr : old_user_msgptr;
059ec3d9
PH
3117
3118 /* If the verb is "warn", messages generated by conditions (verification or
4e88a19f
PH
3119 nested ACLs) are always discarded. This also happens for acceptance verbs
3120 when they actually do accept. Only messages specified at this level are used.
059ec3d9
PH
3121 However, the value of an existing message is available in $acl_verify_message
3122 during expansions. */
3123
4e88a19f
PH
3124 if (verb == ACL_WARN ||
3125 (rc == OK && (verb == ACL_ACCEPT || verb == ACL_DISCARD)))
3126 *log_msgptr = *user_msgptr = NULL;
059ec3d9
PH
3127
3128 if (user_message != NULL)
3129 {
3130 acl_verify_message = old_user_msgptr;
3131 expmessage = expand_string(user_message);
3132 if (expmessage == NULL)
3133 {
3134 if (!expand_string_forcedfail)
3135 log_write(0, LOG_MAIN|LOG_PANIC, "failed to expand ACL message \"%s\": %s",
3136 user_message, expand_string_message);
3137 }
3138 else if (expmessage[0] != 0) *user_msgptr = expmessage;
3139 }
3140
3141 if (log_message != NULL)
3142 {
3143 acl_verify_message = old_log_msgptr;
3144 expmessage = expand_string(log_message);
3145 if (expmessage == NULL)
3146 {
3147 if (!expand_string_forcedfail)
3148 log_write(0, LOG_MAIN|LOG_PANIC, "failed to expand ACL message \"%s\": %s",
3149 log_message, expand_string_message);
3150 }
3151 else if (expmessage[0] != 0)
3152 {
3153 *log_msgptr = (*log_msgptr == NULL)? expmessage :
3154 string_sprintf("%s: %s", expmessage, *log_msgptr);
3155 }
3156 }
3157
3158 /* If no log message, default it to the user message */
3159
3160 if (*log_msgptr == NULL) *log_msgptr = *user_msgptr;
3161 }
3162
3163acl_verify_message = NULL;
3164return rc;
3165}
3166
3167
3168
3169
3170
3171/*************************************************
3172* Get line from a literal ACL *
3173*************************************************/
3174
3175/* This function is passed to acl_read() in order to extract individual lines
3176of a literal ACL, which we access via static pointers. We can destroy the
3177contents because this is called only once (the compiled ACL is remembered).
3178
3179This code is intended to treat the data in the same way as lines in the main
3180Exim configuration file. That is:
3181
3182 . Leading spaces are ignored.
3183
3184 . A \ at the end of a line is a continuation - trailing spaces after the \
3185 are permitted (this is because I don't believe in making invisible things
3186 significant). Leading spaces on the continued part of a line are ignored.
3187
3188 . Physical lines starting (significantly) with # are totally ignored, and
3189 may appear within a sequence of backslash-continued lines.
3190
3191 . Blank lines are ignored, but will end a sequence of continuations.
3192
3193Arguments: none
3194Returns: a pointer to the next line
3195*/
3196
3197
3198static uschar *acl_text; /* Current pointer in the text */
3199static uschar *acl_text_end; /* Points one past the terminating '0' */
3200
3201
3202static uschar *
3203acl_getline(void)
3204{
3205uschar *yield;
3206
3207/* This loop handles leading blank lines and comments. */
3208
3209for(;;)
3210 {
3211 while (isspace(*acl_text)) acl_text++; /* Leading spaces/empty lines */
3212 if (*acl_text == 0) return NULL; /* No more data */
3213 yield = acl_text; /* Potential data line */
3214
3215 while (*acl_text != 0 && *acl_text != '\n') acl_text++;
3216
3217 /* If we hit the end before a newline, we have the whole logical line. If
3218 it's a comment, there's no more data to be given. Otherwise, yield it. */
3219
3220 if (*acl_text == 0) return (*yield == '#')? NULL : yield;
3221
3222 /* After reaching a newline, end this loop if the physical line does not
3223 start with '#'. If it does, it's a comment, and the loop continues. */
3224
3225 if (*yield != '#') break;
3226 }
3227
3228/* This loop handles continuations. We know we have some real data, ending in
3229newline. See if there is a continuation marker at the end (ignoring trailing
3230white space). We know that *yield is not white space, so no need to test for
3231cont > yield in the backwards scanning loop. */
3232
3233for(;;)
3234 {
3235 uschar *cont;
3236 for (cont = acl_text - 1; isspace(*cont); cont--);
3237
3238 /* If no continuation follows, we are done. Mark the end of the line and
3239 return it. */
3240
3241 if (*cont != '\\')
3242 {
3243 *acl_text++ = 0;
3244 return yield;
3245 }
3246
3247 /* We have encountered a continuation. Skip over whitespace at the start of
3248 the next line, and indeed the whole of the next line or lines if they are
3249 comment lines. */
3250
3251 for (;;)
3252 {
3253 while (*(++acl_text) == ' ' || *acl_text == '\t');
3254 if (*acl_text != '#') break;
3255 while (*(++acl_text) != 0 && *acl_text != '\n');
3256 }
3257
3258 /* We have the start of a continuation line. Move all the rest of the data
3259 to join onto the previous line, and then find its end. If the end is not a
3260 newline, we are done. Otherwise loop to look for another continuation. */
3261
3262 memmove(cont, acl_text, acl_text_end - acl_text);
3263 acl_text_end -= acl_text - cont;
3264 acl_text = cont;
3265 while (*acl_text != 0 && *acl_text != '\n') acl_text++;
3266 if (*acl_text == 0) return yield;
3267 }
3268
3269/* Control does not reach here */
3270}
3271
3272
3273
3274
3275
3276/*************************************************
3277* Check access using an ACL *
3278*************************************************/
3279
3280/* This function is called from address_check. It may recurse via
3281acl_check_condition() - hence the use of a level to stop looping. The ACL is
3282passed as a string which is expanded. A forced failure implies no access check
3283is required. If the result is a single word, it is taken as the name of an ACL
3284which is sought in the global ACL tree. Otherwise, it is taken as literal ACL
3285text, complete with newlines, and parsed as such. In both cases, the ACL check
3286is then run. This function uses an auxiliary function for acl_read() to call
3287for reading individual lines of a literal ACL. This is acl_getline(), which
3288appears immediately above.
3289
3290Arguments:
3291 where where called from
3292 addr address item when called from RCPT; otherwise NULL
3293 s the input string; NULL is the same as an empty ACL => DENY
3294 level the nesting level
3295 user_msgptr where to put a user error (for SMTP response)
3296 log_msgptr where to put a logging message (not for SMTP response)
3297
3298Returns: OK access is granted
3299 DISCARD access is apparently granted...
3300 FAIL access is denied
3301 FAIL_DROP access is denied; drop the connection
3302 DEFER can't tell at the moment
3303 ERROR disaster
3304*/
3305
3306static int
3307acl_check_internal(int where, address_item *addr, uschar *s, int level,
3308 uschar **user_msgptr, uschar **log_msgptr)
3309{
3310int fd = -1;
3311acl_block *acl = NULL;
3312uschar *acl_name = US"inline ACL";
3313uschar *ss;
3314
3315/* Catch configuration loops */
3316
3317if (level > 20)
3318 {
3319 *log_msgptr = US"ACL nested too deep: possible loop";
3320 return ERROR;
3321 }
3322
3323if (s == NULL)
3324 {
3325 HDEBUG(D_acl) debug_printf("ACL is NULL: implicit DENY\n");
3326 return FAIL;
3327 }
3328
3329/* At top level, we expand the incoming string. At lower levels, it has already
3330been expanded as part of condition processing. */
3331
3332if (level == 0)
3333 {
3334 ss = expand_string(s);
3335 if (ss == NULL)
3336 {
3337 if (expand_string_forcedfail) return OK;
3338 *log_msgptr = string_sprintf("failed to expand ACL string \"%s\": %s", s,
3339 expand_string_message);
3340 return ERROR;
3341 }
3342 }
3343else ss = s;
3344
3345while (isspace(*ss))ss++;
3346
3347/* If we can't find a named ACL, the default is to parse it as an inline one.
3348(Unless it begins with a slash; non-existent files give rise to an error.) */
3349
3350acl_text = ss;
3351
3352/* Handle the case of a string that does not contain any spaces. Look for a
3353named ACL among those read from the configuration, or a previously read file.
3354It is possible that the pointer to the ACL is NULL if the configuration
3355contains a name with no data. If not found, and the text begins with '/',
3356read an ACL from a file, and save it so it can be re-used. */
3357
3358if (Ustrchr(ss, ' ') == NULL)
3359 {
3360 tree_node *t = tree_search(acl_anchor, ss);
3361 if (t != NULL)
3362 {
3363 acl = (acl_block *)(t->data.ptr);
3364 if (acl == NULL)
3365 {
3366 HDEBUG(D_acl) debug_printf("ACL \"%s\" is empty: implicit DENY\n", ss);
3367 return FAIL;
3368 }
3369 acl_name = string_sprintf("ACL \"%s\"", ss);
3370 HDEBUG(D_acl) debug_printf("using ACL \"%s\"\n", ss);
3371 }
3372
3373 else if (*ss == '/')
3374 {
3375 struct stat statbuf;
3376 fd = Uopen(ss, O_RDONLY, 0);
3377 if (fd < 0)
3378 {
3379 *log_msgptr = string_sprintf("failed to open ACL file \"%s\": %s", ss,
3380 strerror(errno));
3381 return ERROR;
3382 }
3383
3384 if (fstat(fd, &statbuf) != 0)
3385 {
3386 *log_msgptr = string_sprintf("failed to fstat ACL file \"%s\": %s", ss,
3387 strerror(errno));
3388 return ERROR;
3389 }
3390
3391 acl_text = store_get(statbuf.st_size + 1);
3392 acl_text_end = acl_text + statbuf.st_size + 1;
3393
3394 if (read(fd, acl_text, statbuf.st_size) != statbuf.st_size)
3395 {
3396 *log_msgptr = string_sprintf("failed to read ACL file \"%s\": %s",
3397 ss, strerror(errno));
3398 return ERROR;
3399 }
3400 acl_text[statbuf.st_size] = 0;
f1e894f3 3401 (void)close(fd);
059ec3d9
PH
3402
3403 acl_name = string_sprintf("ACL \"%s\"", ss);
3404 HDEBUG(D_acl) debug_printf("read ACL from file %s\n", ss);
3405 }
3406 }
3407
3408/* Parse an ACL that is still in text form. If it came from a file, remember it
3409in the ACL tree, having read it into the POOL_PERM store pool so that it
3410persists between multiple messages. */
3411
3412if (acl == NULL)
3413 {
3414 int old_pool = store_pool;
3415 if (fd >= 0) store_pool = POOL_PERM;
3416 acl = acl_read(acl_getline, log_msgptr);
3417 store_pool = old_pool;
3418 if (acl == NULL && *log_msgptr != NULL) return ERROR;
3419 if (fd >= 0)
3420 {
3421 tree_node *t = store_get_perm(sizeof(tree_node) + Ustrlen(ss));
3422 Ustrcpy(t->name, ss);
3423 t->data.ptr = acl;
3424 (void)tree_insertnode(&acl_anchor, t);
3425 }
3426 }
3427
3428/* Now we have an ACL to use. It's possible it may be NULL. */
3429
3430while (acl != NULL)
3431 {
3432 int cond;
3433 int basic_errno = 0;
3434 BOOL endpass_seen = FALSE;
3435
3436 *log_msgptr = *user_msgptr = NULL;
3437 acl_temp_details = FALSE;
3438
3439 if (where == ACL_WHERE_QUIT &&
3440 acl->verb != ACL_ACCEPT &&
3441 acl->verb != ACL_WARN)
3442 {
3443 *log_msgptr = string_sprintf("\"%s\" is not allowed in a QUIT ACL",
3444 verbs[acl->verb]);
3445 return ERROR;
3446 }
3447
3448 HDEBUG(D_acl) debug_printf("processing \"%s\"\n", verbs[acl->verb]);
3449
3450 /* Clear out any search error message from a previous check before testing
3451 this condition. */
3452
3453 search_error_message = NULL;
3454 cond = acl_check_condition(acl->verb, acl->condition, where, addr, level,
3455 &endpass_seen, user_msgptr, log_msgptr, &basic_errno);
3456
3457 /* Handle special returns: DEFER causes a return except on a WARN verb;
3458 ERROR always causes a return. */
3459
3460 switch (cond)
3461 {
3462 case DEFER:
3463 HDEBUG(D_acl) debug_printf("%s: condition test deferred\n", verbs[acl->verb]);
3464 if (basic_errno != ERRNO_CALLOUTDEFER)
3465 {
3466 if (search_error_message != NULL && *search_error_message != 0)
3467 *log_msgptr = search_error_message;
3468 if (smtp_return_error_details) acl_temp_details = TRUE;
3469 }
3470 else
3471 {
3472 acl_temp_details = TRUE;
3473 }
3474 if (acl->verb != ACL_WARN) return DEFER;
3475 break;
3476
3477 default: /* Paranoia */
3478 case ERROR:
3479 HDEBUG(D_acl) debug_printf("%s: condition test error\n", verbs[acl->verb]);
3480 return ERROR;
3481
3482 case OK:
3483 HDEBUG(D_acl) debug_printf("%s: condition test succeeded\n",
3484 verbs[acl->verb]);
3485 break;
3486
3487 case FAIL:
3488 HDEBUG(D_acl) debug_printf("%s: condition test failed\n", verbs[acl->verb]);
3489 break;
3490
3491 /* DISCARD and DROP can happen only from a nested ACL condition, and
3492 DISCARD can happen only for an "accept" or "discard" verb. */
3493
3494 case DISCARD:
3495 HDEBUG(D_acl) debug_printf("%s: condition test yielded \"discard\"\n",
3496 verbs[acl->verb]);
3497 break;
3498
3499 case FAIL_DROP:
3500 HDEBUG(D_acl) debug_printf("%s: condition test yielded \"drop\"\n",
3501 verbs[acl->verb]);
3502 break;
3503 }
3504
3505 /* At this point, cond for most verbs is either OK or FAIL or (as a result of
3506 a nested ACL condition) FAIL_DROP. However, for WARN, cond may be DEFER, and
3507 for ACCEPT and DISCARD, it may be DISCARD after a nested ACL call. */
3508
3509 switch(acl->verb)
3510 {
3511 case ACL_ACCEPT:
3512 if (cond == OK || cond == DISCARD) return cond;
3513 if (endpass_seen)
3514 {
3515 HDEBUG(D_acl) debug_printf("accept: endpass encountered - denying access\n");
3516 return cond;
3517 }
3518 break;
3519
3520 case ACL_DEFER:
3521 if (cond == OK)
3522 {
3523 acl_temp_details = TRUE;
3524 return DEFER;
3525 }
3526 break;
3527
3528 case ACL_DENY:
3529 if (cond == OK) return FAIL;
3530 break;
3531
3532 case ACL_DISCARD:
3533 if (cond == OK || cond == DISCARD) return DISCARD;
3534 if (endpass_seen)
3535 {
3536 HDEBUG(D_acl) debug_printf("discard: endpass encountered - denying access\n");
3537 return cond;
3538 }
3539 break;
3540
3541 case ACL_DROP:
3542 if (cond == OK) return FAIL_DROP;
3543 break;
3544
3545 case ACL_REQUIRE:
3546 if (cond != OK) return cond;
3547 break;
3548
3549 case ACL_WARN:
3550 if (cond == OK)
3551 acl_warn(where, *user_msgptr, *log_msgptr);
49826d12 3552 else if (cond == DEFER && (log_extra_selector & LX_acl_warn_skipped) != 0)
9c7a242c
PH
3553 log_write(0, LOG_MAIN, "%s Warning: ACL \"warn\" statement skipped: "
3554 "condition test deferred%s%s", host_and_ident(TRUE),
3555 (*log_msgptr == NULL)? US"" : US": ",
3556 (*log_msgptr == NULL)? US"" : *log_msgptr);
059ec3d9
PH
3557 *log_msgptr = *user_msgptr = NULL; /* In case implicit DENY follows */
3558 break;
3559
3560 default:
3561 log_write(0, LOG_MAIN|LOG_PANIC_DIE, "internal ACL error: unknown verb %d",
3562 acl->verb);
3563 break;
3564 }
3565
3566 /* Pass to the next ACL item */
3567
3568 acl = acl->next;
3569 }
3570
3571/* We have reached the end of the ACL. This is an implicit DENY. */
3572
3573HDEBUG(D_acl) debug_printf("end of %s: implicit DENY\n", acl_name);
3574return FAIL;
3575}
3576
3577
3578/*************************************************
3579* Check access using an ACL *
3580*************************************************/
3581
3582/* This is the external interface for ACL checks. It sets up an address and the
3583expansions for $domain and $local_part when called after RCPT, then calls
3584acl_check_internal() to do the actual work.
3585
3586Arguments:
3587 where ACL_WHERE_xxxx indicating where called from
64ffc24f 3588 recipient RCPT address for RCPT check, else NULL
059ec3d9
PH
3589 s the input string; NULL is the same as an empty ACL => DENY
3590 user_msgptr where to put a user error (for SMTP response)
3591 log_msgptr where to put a logging message (not for SMTP response)
3592
3593Returns: OK access is granted by an ACCEPT verb
3594 DISCARD access is granted by a DISCARD verb
3595 FAIL access is denied
3596 FAIL_DROP access is denied; drop the connection
3597 DEFER can't tell at the moment
3598 ERROR disaster
3599*/
3600
3601int
64ffc24f 3602acl_check(int where, uschar *recipient, uschar *s, uschar **user_msgptr,
059ec3d9
PH
3603 uschar **log_msgptr)
3604{
3605int rc;
3606address_item adb;
64ffc24f 3607address_item *addr = NULL;
059ec3d9
PH
3608
3609*user_msgptr = *log_msgptr = NULL;
3610sender_verified_failed = NULL;
fe0dab11 3611ratelimiters_cmd = NULL;
6ea85e9a 3612log_reject_target = LOG_MAIN|LOG_REJECT;
059ec3d9
PH
3613
3614if (where == ACL_WHERE_RCPT)
3615 {
3616 adb = address_defaults;
3617 addr = &adb;
64ffc24f 3618 addr->address = recipient;
059ec3d9
PH
3619 if (deliver_split_address(addr) == DEFER)
3620 {
3621 *log_msgptr = US"defer in percent_hack_domains check";
3622 return DEFER;
3623 }
3624 deliver_domain = addr->domain;
3625 deliver_localpart = addr->local_part;
3626 }
059ec3d9
PH
3627
3628rc = acl_check_internal(where, addr, s, 0, user_msgptr, log_msgptr);
3629
64ffc24f
PH
3630deliver_domain = deliver_localpart = deliver_address_data =
3631 sender_address_data = NULL;
059ec3d9
PH
3632
3633/* A DISCARD response is permitted only for message ACLs, excluding the PREDATA
3634ACL, which is really in the middle of an SMTP command. */
3635
3636if (rc == DISCARD)
3637 {
3638 if (where > ACL_WHERE_NOTSMTP || where == ACL_WHERE_PREDATA)
3639 {
3640 log_write(0, LOG_MAIN|LOG_PANIC, "\"discard\" verb not allowed in %s "
3641 "ACL", acl_wherenames[where]);
3642 return ERROR;
3643 }
3644 return DISCARD;
3645 }
3646
3647/* A DROP response is not permitted from MAILAUTH */
3648
3649if (rc == FAIL_DROP && where == ACL_WHERE_MAILAUTH)
3650 {
3651 log_write(0, LOG_MAIN|LOG_PANIC, "\"drop\" verb not allowed in %s "
3652 "ACL", acl_wherenames[where]);
3653 return ERROR;
3654 }
3655
4e88a19f
PH
3656/* Before giving a response, take a look at the length of any user message, and
3657split it up into multiple lines if possible. */
059ec3d9 3658
e28326d8
PH
3659*user_msgptr = string_split_message(*user_msgptr);
3660if (fake_response != OK)
3661 fake_response_text = string_split_message(fake_response_text);
059ec3d9
PH
3662
3663return rc;
3664}
3665
38a0a95f
PH
3666
3667
3668/*************************************************
3669* Create ACL variable *
3670*************************************************/
3671
3672/* Create an ACL variable or reuse an existing one. ACL variables are in a
3673binary tree (see tree.c) with acl_var_c and acl_var_m as root nodes.
3674
3675Argument:
3676 name pointer to the variable's name, starting with c or m
3677
3678Returns the pointer to variable's tree node
3679*/
3680
3681tree_node *
3682acl_var_create(uschar *name)
3683{
3684tree_node *node, **root;
3685root = (name[0] == 'c')? &acl_var_c : &acl_var_m;
3686node = tree_search(*root, name);
3687if (node == NULL)
3688 {
3689 node = store_get(sizeof(tree_node) + Ustrlen(name));
3690 Ustrcpy(node->name, name);
3691 (void)tree_insertnode(root, node);
3692 }
3693node->data.ptr = NULL;
3694return node;
3695}
3696
3697
3698
3699/*************************************************
3700* Write an ACL variable in spool format *
3701*************************************************/
3702
3703/* This function is used as a callback for tree_walk when writing variables to
3704the spool file. To retain spool file compatibility, what is written is -aclc or
3705-aclm followed by the rest of the name and the data length, space separated,
3706then the value itself, starting on a new line, and terminated by an additional
3707newline. When we had only numbered ACL variables, the first line might look
3708like this: "-aclc 5 20". Now it might be "-aclc foo 20" for the variable called
3709acl_cfoo.
3710
3711Arguments:
3712 name of the variable
3713 value of the variable
3714 ctx FILE pointer (as a void pointer)
3715
3716Returns: nothing
3717*/
3718
3719void
3720acl_var_write(uschar *name, uschar *value, void *ctx)
3721{
3722FILE *f = (FILE *)ctx;
3723fprintf(f, "-acl%c %s %d\n%s\n", name[0], name+1, Ustrlen(value), value);
3724}
3725
059ec3d9 3726/* End of acl.c */