The FreeRADIUS server $Id: 15bac2a4c627c01d1aa2047687b3418955ac7f00 $
Loading...
Searching...
No Matches
rlm_ldap.c
Go to the documentation of this file.
1/*
2 * This program is is free software; you can redistribute it and/or modify
3 * it under the terms of the GNU General Public License as published by
4 * the Free Software Foundation; either version 2 of the License, or (at
5 * your option) any later version.
6 *
7 * This program is distributed in the hope that it will be useful,
8 * but WITHOUT ANY WARRANTY; without even the implied warranty of
9 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
10 * GNU General Public License for more details.
11 *
12 * You should have received a copy of the GNU General Public License
13 * along with this program; if not, write to the Free Software
14 * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301, USA
15 */
16
17/**
18 * $Id: 03a109bb62844ea1ebde1022e284a3c2a00a7cf9 $
19 * @file rlm_ldap.c
20 * @brief LDAP authorization and authentication module.
21 *
22 * @author Arran Cudbard-Bell (a.cudbardb@freeradius.org)
23 * @author Alan DeKok (aland@freeradius.org)
24 *
25 * @copyright 2012,2015 Arran Cudbard-Bell (a.cudbardb@freeradius.org)
26 * @copyright 2013,2015 Network RADIUS SAS (legal@networkradius.com)
27 * @copyright 2012 Alan DeKok (aland@freeradius.org)
28 * @copyright 1999-2013 The FreeRADIUS Server Project.
29 */
30RCSID("$Id: 03a109bb62844ea1ebde1022e284a3c2a00a7cf9 $")
31
33
34#include <freeradius-devel/util/debug.h>
35#include <freeradius-devel/util/table.h>
36#include <freeradius-devel/util/uri.h>
37#include <freeradius-devel/util/value.h>
38
39#include <freeradius-devel/ldap/conf.h>
40#include <freeradius-devel/ldap/base.h>
41
42#include <freeradius-devel/server/map_proc.h>
43#include <freeradius-devel/server/module_rlm.h>
44#include <freeradius-devel/server/rcode.h>
45
46#include <freeradius-devel/unlang/xlat_func.h>
47#include <freeradius-devel/unlang/action.h>
48
49#include <ldap.h>
50#include "rlm_ldap.h"
51
56
65
66typedef struct {
67 char const *attr;
69 tmpl_t const *tmpl;
76
77/** Call environment used in the profile xlat
78 */
79typedef struct {
80 fr_value_box_t profile_filter; //!< Filter to use when searching for users.
81 map_list_t *profile_map; //!< List of maps to apply to the profile.
83
84static int ldap_update_section_parse(TALLOC_CTX *ctx, call_env_parsed_head_t *out, tmpl_rules_t const *t_rules, CONF_ITEM *ci, call_env_ctx_t const *cec, call_env_parser_t const *rule);
85static int ldap_mod_section_parse(TALLOC_CTX *ctx, call_env_parsed_head_t *out, tmpl_rules_t const *t_rules, CONF_ITEM *ci, call_env_ctx_t const *cec, call_env_parser_t const *rule);
86
87static int ldap_group_filter_parse(TALLOC_CTX *ctx, void *out, tmpl_rules_t const *t_rules, CONF_ITEM *ci, call_env_ctx_t const *cec, UNUSED call_env_parser_t const *rule);
88
96
98 { FR_CONF_OFFSET("scope", rlm_ldap_t, profile.obj_scope), .dflt = "base",
100 { FR_CONF_OFFSET("attribute", rlm_ldap_t, profile.attr) },
101 { FR_CONF_OFFSET("attribute_suspend", rlm_ldap_t, profile.attr_suspend) },
102 { FR_CONF_OFFSET("check_attribute", rlm_ldap_t, profile.check_attr) },
103 { FR_CONF_OFFSET("sort_by", rlm_ldap_t, profile.obj_sort_by) },
104 { FR_CONF_OFFSET("fallthrough_attribute", rlm_ldap_t, profile.fallthrough_attr) },
105 { FR_CONF_OFFSET("fallthrough_default", rlm_ldap_t, profile.fallthrough_def), .dflt = "yes" },
107};
108
109/*
110 * User configuration
111 */
113 { FR_CONF_OFFSET("scope", rlm_ldap_t, user.obj_scope), .dflt = "sub",
114 .func = cf_table_parse_int, .uctx = &(cf_table_parse_ctx_t){ .table = fr_ldap_scope, .len = &fr_ldap_scope_len } },
115 { FR_CONF_OFFSET("sort_by", rlm_ldap_t, user.obj_sort_by) },
116
117 { FR_CONF_OFFSET("access_attribute", rlm_ldap_t, user.obj_access_attr) },
118 { FR_CONF_OFFSET("access_positive", rlm_ldap_t, user.access_positive), .dflt = "yes" },
119 { FR_CONF_OFFSET("access_value_negate", rlm_ldap_t, user.access_value_negate), .dflt = "false" },
120 { FR_CONF_OFFSET("access_value_suspend", rlm_ldap_t, user.access_value_suspend), .dflt = "suspended" },
121 { FR_CONF_OFFSET_IS_SET("expect_password", FR_TYPE_BOOL, 0, rlm_ldap_t, user.expect_password) },
123};
124
125/*
126 * Group configuration
127 */
129 { FR_CONF_OFFSET("filter", rlm_ldap_t, group.obj_filter) },
130 { FR_CONF_OFFSET("scope", rlm_ldap_t, group.obj_scope), .dflt = "sub",
131 .func = cf_table_parse_int, .uctx = &(cf_table_parse_ctx_t){ .table = fr_ldap_scope, .len = &fr_ldap_scope_len } },
132
133 { FR_CONF_OFFSET("name_attribute", rlm_ldap_t, group.obj_name_attr), .dflt = "cn" },
134 { FR_CONF_OFFSET("membership_attribute", rlm_ldap_t, group.userobj_membership_attr) },
135 { FR_CONF_OFFSET_FLAGS("membership_filter", CONF_FLAG_XLAT, rlm_ldap_t, group.obj_membership_filter) },
136 { FR_CONF_OFFSET("cacheable_name", rlm_ldap_t, group.cacheable_name), .dflt = "no" },
137 { FR_CONF_OFFSET("cacheable_dn", rlm_ldap_t, group.cacheable_dn), .dflt = "no" },
138 { FR_CONF_OFFSET("cache_attribute", rlm_ldap_t, group.cache_attribute) },
139 { FR_CONF_OFFSET("group_attribute", rlm_ldap_t, group.attribute) },
140 { FR_CONF_OFFSET("allow_dangling_group_ref", rlm_ldap_t, group.allow_dangling_refs), .dflt = "no" },
141 { FR_CONF_OFFSET("skip_on_suspend", rlm_ldap_t, group.skip_on_suspend), .dflt = "yes"},
143};
144
145static const conf_parser_t module_config[] = {
146 /*
147 * Pool config items
148 */
149 { FR_CONF_OFFSET_FLAGS("server", CONF_FLAG_MULTI, rlm_ldap_t, handle_config.server_str) }, /* Do not set to required */
150
151 /*
152 * Common LDAP conf parsers
153 */
155
156 { FR_CONF_OFFSET("valuepair_attribute", rlm_ldap_t, valuepair_attr) },
157
158#ifdef LDAP_CONTROL_X_SESSION_TRACKING
159 { FR_CONF_OFFSET("session_tracking", rlm_ldap_t, session_tracking), .dflt = "no" },
160#endif
161
162#ifdef WITH_EDIR
163 /* support for eDirectory Universal Password */
164 { FR_CONF_OFFSET("edir", rlm_ldap_t, edir) }, /* NULL defaults to "no" */
165
166 /*
167 * Attempt to bind with the cleartext password we got from eDirectory
168 * Universal password for additional authorization checks.
169 */
170 { FR_CONF_OFFSET("edir_autz", rlm_ldap_t, edir_autz) }, /* NULL defaults to "no" */
171#endif
172
173 { FR_CONF_POINTER("user", 0, CONF_FLAG_SUBSECTION, NULL), .subcs = (void const *) user_config },
174
175 { FR_CONF_POINTER("group", 0, CONF_FLAG_SUBSECTION, NULL), .subcs = (void const *) group_config },
176
177 { FR_CONF_POINTER("profile", 0, CONF_FLAG_SUBSECTION, NULL), .subcs = (void const *) profile_config },
178
179 { FR_CONF_OFFSET_SUBSECTION("pool", 0, rlm_ldap_t, trunk_conf, trunk_config ) },
180
181 { FR_CONF_OFFSET_SUBSECTION("bind_pool", 0, rlm_ldap_t, bind_trunk_conf, trunk_config ) },
182
184};
185
186#define USER_CALL_ENV_COMMON(_struct) \
187 { FR_CALL_ENV_OFFSET("base_dn", FR_TYPE_STRING, CALL_ENV_FLAG_REQUIRED | CALL_ENV_FLAG_CONCAT, _struct, user_base), .pair.dflt = "", .pair.dflt_quote = T_SINGLE_QUOTED_STRING }, \
188 { FR_CALL_ENV_OFFSET("filter", FR_TYPE_STRING, CALL_ENV_FLAG_NULLABLE | CALL_ENV_FLAG_CONCAT, _struct, user_filter), .pair.dflt = "(&)", .pair.dflt_quote = T_SINGLE_QUOTED_STRING }
189
205
206/** Parameters to allow ldap_update_section_parse to be reused
207 */
212
215 .env = (call_env_parser_t[]) {
218 .map_offset = offsetof(ldap_autz_call_env_t, user_map),
219 .expect_password_offset = offsetof(ldap_autz_call_env_t, expect_password)
220 } },
222 ((call_env_parser_t[]) {
225 })) },
227 ((call_env_parser_t[]) {
230 .pair.func = ldap_group_filter_parse,
231 .pair.escape = {
232 .box_escape = {
233 .func = fr_ldap_box_escape,
235 .always_escape = false,
236 },
238 },
239 .pair.literals_safe_for = (fr_value_box_safe_for_t)fr_ldap_box_escape,
240 },
242 })) },
244 ((call_env_parser_t[]) {
247 .pair.dflt = "(&)", .pair.dflt_quote = T_SINGLE_QUOTED_STRING }, //!< Correct filter for when the DN is known.
249 } )) },
251 }
252};
253
254#define USERMOD_ENV(_section) static const call_env_method_t _section ## _usermod_method_env = { \
255 FR_CALL_ENV_METHOD_OUT(ldap_usermod_call_env_t), \
256 .env = (call_env_parser_t[]) { \
257 { FR_CALL_ENV_SUBSECTION("user", NULL, CALL_ENV_FLAG_REQUIRED, \
258 ((call_env_parser_t[]) { \
259 USER_CALL_ENV_COMMON(ldap_usermod_call_env_t), CALL_ENV_TERMINATOR \
260 })) }, \
261 { FR_CALL_ENV_SUBSECTION_FUNC(STRINGIFY(_section), CF_IDENT_ANY, CALL_ENV_FLAG_SUBSECTION | CALL_ENV_FLAG_PARSE_MISSING, ldap_mod_section_parse) }, \
262 CALL_ENV_TERMINATOR \
263 } \
264}
265
266USERMOD_ENV(accounting);
268
271 .env = (call_env_parser_t[]) {
273 ((call_env_parser_t[]) {
276 })) },
278 ((call_env_parser_t[]) {
281 .pair.func = ldap_group_filter_parse,
282 .pair.escape = {
283 .box_escape = {
284 .func = fr_ldap_box_escape,
286 .always_escape = false,
287 },
289 },
290 .pair.literals_safe_for = (fr_value_box_safe_for_t)fr_ldap_box_escape,
291 },
293 })) },
295 }
296};
297
300 .env = (call_env_parser_t[]) {
303 .map_offset = offsetof(ldap_xlat_profile_call_env_t, profile_map),
304 .expect_password_offset = -1
305 } },
307 ((call_env_parser_t[]) {
309 .pair.dflt = "(&)", .pair.dflt_quote = T_SINGLE_QUOTED_STRING }, //!< Correct filter for when the DN is known.
311 })) },
313 }
314};
315
317
320 { .out = &dict_freeradius, .proto = "freeradius" },
321 { NULL }
322};
323
331
334 { .out = &attr_password, .name = "Password", .type = FR_TYPE_TLV, .dict = &dict_freeradius },
335 { .out = &attr_cleartext_password, .name = "Password.Cleartext", .type = FR_TYPE_STRING, .dict = &dict_freeradius },
336 { .out = &attr_crypt_password, .name = "Password.Crypt", .type = FR_TYPE_STRING, .dict = &dict_freeradius },
337 { .out = &attr_ldap_userdn, .name = "LDAP-UserDN", .type = FR_TYPE_STRING, .dict = &dict_freeradius },
338 { .out = &attr_nt_password, .name = "Password.NT", .type = FR_TYPE_OCTETS, .dict = &dict_freeradius },
339 { .out = &attr_password_with_header, .name = "Password.With-Header", .type = FR_TYPE_STRING, .dict = &dict_freeradius },
340 { .out = &attr_expr_bool_enum, .name = "Expr-Bool-Enum", .type = FR_TYPE_BOOL, .dict = &dict_freeradius },
341
342 { NULL }
343};
344
345extern global_lib_autoinst_t const *rlm_ldap_lib[];
350
351/** Holds state of in progress async authentication
352 *
353 */
361
362/** Holds state of in progress ldap user modifications
363 *
364 */
378
379/** Holds state of in progress LDAP map
380 *
381 */
382typedef struct {
383 map_list_t const *maps;
384 LDAPURLDesc *ldap_url;
387 LDAPControl *serverctrls[LDAP_MAX_CONTROLS];
389
395
397 { L("ldap://"), LDAP_SCHEME_UNIX },
398 { L("ldapi://"), LDAP_SCHEME_TCP },
399 { L("ldaps://"), LDAP_SCHEME_TCP_SSL },
400};
402
403/** This is the common function that actually ends up doing all the URI escaping
404 */
405#define LDAP_URI_SAFE_FOR (fr_value_box_safe_for_t)fr_ldap_uri_escape_func
406
408 { .required = true, .concat = true, .type = FR_TYPE_STRING },
410};
411
413 { .required = true, .concat = true, .type = FR_TYPE_STRING },
415};
416
417/** Escape LDAP string
418 *
419 * @ingroup xlat_functions
420 */
422 UNUSED xlat_ctx_t const *xctx,
423 request_t *request, fr_value_box_list_t *in)
424{
425 fr_value_box_t *vb, *in_vb = fr_value_box_list_head(in);
426 fr_sbuff_t sbuff;
427 fr_sbuff_uctx_talloc_t sbuff_ctx;
428 size_t len;
429
430 MEM(vb = fr_value_box_alloc_null(ctx));
431
432 /*
433 * If it's already safe, just copy it over.
434 */
436 fr_value_box_copy(vb, vb, in_vb);
437
439 return XLAT_ACTION_DONE;
440 }
441
442 /*
443 * Maximum space needed for output would be 3 times the input if every
444 * char needed escaping
445 */
446 if (!fr_sbuff_init_talloc(vb, &sbuff, &sbuff_ctx, in_vb->vb_length * 3, in_vb->vb_length * 3)) {
447 REDEBUG("Failed to allocate buffer for escaped string");
448 talloc_free(vb);
449 return XLAT_ACTION_FAIL;
450 }
451
452 /*
453 * Call the escape function, including the space for the trailing NULL
454 */
455 len = fr_ldap_uri_escape_func(request, fr_sbuff_buff(&sbuff), in_vb->vb_length * 3 + 1, in_vb->vb_strvalue, NULL);
456
457 /*
458 * Trim buffer to fit used space and assign to box
459 */
460 fr_sbuff_trim_talloc(&sbuff, len);
461 fr_value_box_strdup_shallow(vb, NULL, fr_sbuff_buff(&sbuff), in_vb->tainted);
462
464 return XLAT_ACTION_DONE;
465}
466
468 { .required = true, .concat = true, .type = FR_TYPE_STRING },
470};
471
472/** Unescape LDAP string
473 *
474 * @ingroup xlat_functions
475 */
477 UNUSED xlat_ctx_t const *xctx,
478 request_t *request, fr_value_box_list_t *in)
479{
480 fr_value_box_t *vb, *in_vb = fr_value_box_list_head(in);
481 fr_sbuff_t sbuff;
482 fr_sbuff_uctx_talloc_t sbuff_ctx;
483 size_t len;
484
485 MEM(vb = fr_value_box_alloc_null(ctx));
486 /*
487 * Maximum space needed for output will be the same as the input
488 */
489 if (!fr_sbuff_init_talloc(vb, &sbuff, &sbuff_ctx, in_vb->vb_length, in_vb->vb_length)) {
490 REDEBUG("Failed to allocate buffer for unescaped string");
491 talloc_free(vb);
492 return XLAT_ACTION_FAIL;
493 }
494
495 /*
496 * Call the unescape function, including the space for the trailing NULL
497 */
498 len = fr_ldap_uri_unescape_func(request, fr_sbuff_buff(&sbuff), in_vb->vb_length + 1, in_vb->vb_strvalue, NULL);
499
500 /*
501 * Trim buffer to fit used space and assign to box
502 */
503 fr_sbuff_trim_talloc(&sbuff, len);
504 fr_value_box_strdup_shallow(vb, NULL, fr_sbuff_buff(&sbuff), in_vb->tainted);
506
507 return XLAT_ACTION_DONE;
508}
509
510/** Escape function for a part of an LDAP URI
511 *
512 */
513static int ldap_uri_part_escape(fr_value_box_t *vb, UNUSED void *uctx)
514{
515 fr_sbuff_t sbuff;
516 fr_sbuff_uctx_talloc_t sbuff_ctx;
517 size_t len;
518
519 /*
520 * Maximum space needed for output would be 3 times the input if every
521 * char needed escaping
522 */
523 if (!fr_sbuff_init_talloc(vb, &sbuff, &sbuff_ctx, vb->vb_length * 3, vb->vb_length * 3)) {
524 fr_strerror_printf_push("Failed to allocate buffer for escaped argument");
525 return -1;
526 }
527
528 /*
529 * Call the escape function, including the space for the trailing NULL
530 */
531 len = fr_ldap_uri_escape_func(NULL, fr_sbuff_buff(&sbuff), vb->vb_length * 3 + 1, vb->vb_strvalue, NULL);
532
533 fr_sbuff_trim_talloc(&sbuff, len);
535
536 return 0;
537}
538
539/** Callback when LDAP query times out
540 *
541 */
543{
544 fr_ldap_query_t *query = talloc_get_type_abort(uctx, fr_ldap_query_t);
545 trunk_request_t *treq;
546 request_t *request;
547
548 /*
549 * If the trunk request has completed but the query
550 * has not yet resumed, query->treq will be NULL
551 */
552 if (!query->treq) return;
553
554 treq = talloc_get_type_abort(query->treq, trunk_request_t);
555 request = treq->request;
556
557 ROPTIONAL(RERROR, ERROR, "Timeout waiting for LDAP query");
558
560
561 query->ret = LDAP_RESULT_TIMEOUT;
563}
564
565/** Callback when resuming after async ldap query is completed
566 *
567 */
569 xlat_ctx_t const *xctx,
570 request_t *request, UNUSED fr_value_box_list_t *in)
571{
572 fr_ldap_query_t *query = talloc_get_type_abort(xctx->rctx, fr_ldap_query_t);
573 fr_ldap_connection_t *ldap_conn = query->ldap_conn;
574 fr_value_box_t *vb = NULL;
575 LDAPMessage *msg;
576 struct berval **values;
577 char const **attr;
578 int count, i;
579
580 if (query->ret != LDAP_RESULT_SUCCESS) return XLAT_ACTION_FAIL;
581
582 /*
583 * We only parse "entries"
584 */
585 for (msg = ldap_first_entry(ldap_conn->handle, query->result); msg; msg = ldap_next_entry(ldap_conn->handle, msg)) {
586 for (attr = query->search.attrs; *attr; attr++) {
587 values = ldap_get_values_len(ldap_conn->handle, msg, *attr);
588 if (!values) {
589 RDEBUG2("No \"%s\" attributes found in specified object", *attr);
590 continue;
591 }
592
593 count = ldap_count_values_len(values);
594 for (i = 0; i < count; i++) {
595 MEM(vb = fr_value_box_alloc_null(ctx));
596 if (fr_value_box_bstrndup(vb, vb, NULL, values[i]->bv_val, values[i]->bv_len, true) < 0) {
597 talloc_free(vb);
598 RPERROR("Failed creating value from LDAP response");
599 break;
600 }
602 }
603 ldap_value_free_len(values);
604 }
605 }
606
607 talloc_free(query);
608
609 return XLAT_ACTION_DONE;
610}
611
612/** Callback for signalling async ldap query
613 *
614 */
615static void ldap_xlat_signal(xlat_ctx_t const *xctx, request_t *request, UNUSED fr_signal_t action)
616{
617 fr_ldap_query_t *query = talloc_get_type_abort(xctx->rctx, fr_ldap_query_t);
618
619 if (!query->treq) return;
620
621 RDEBUG2("Forcefully cancelling pending LDAP query");
622
624}
625
626/*
627 * If a part doesn't have an escaping function, parsing will fail unless the input
628 * was marked up with a safe_for value by the ldap arg parsing, i.e. was a literal
629 * input argument to the xlat.
630 *
631 * This is equivalent to the old "tainted_allowed" flag.
632 */
634 { .name = "scheme", .safe_for = LDAP_URI_SAFE_FOR, .terminals = &FR_SBUFF_TERMS(L(":")), .part_adv = { [':'] = 1 }, .extra_skip = 2 },
635 { .name = "host", .safe_for = LDAP_URI_SAFE_FOR, .terminals = &FR_SBUFF_TERMS(L(":"), L("/")), .part_adv = { [':'] = 1, ['/'] = 2 } },
636 { .name = "port", .safe_for = LDAP_URI_SAFE_FOR, .terminals = &FR_SBUFF_TERMS(L("/")), .part_adv = { ['/'] = 1 } },
637 { .name = "dn", .safe_for = LDAP_URI_SAFE_FOR, .terminals = &FR_SBUFF_TERMS(L("?")), .part_adv = { ['?'] = 1 }, .func = ldap_uri_part_escape },
638 { .name = "attrs", .safe_for = LDAP_URI_SAFE_FOR, .terminals = &FR_SBUFF_TERMS(L("?")), .part_adv = { ['?'] = 1 }},
639 { .name = "scope", .safe_for = LDAP_URI_SAFE_FOR, .terminals = &FR_SBUFF_TERMS(L("?")), .part_adv = { ['?'] = 1 }, .func = ldap_uri_part_escape },
640 { .name = "filter", .safe_for = LDAP_URI_SAFE_FOR, .terminals = &FR_SBUFF_TERMS(L("?")), .part_adv = { ['?'] = 1}, .func = ldap_uri_part_escape },
641 { .name = "exts", .safe_for = LDAP_URI_SAFE_FOR, .func = ldap_uri_part_escape },
643};
644
645static fr_uri_part_t const ldap_dn_parts[] = {
646 { .name = "dn", .safe_for = LDAP_URI_SAFE_FOR , .func = ldap_uri_part_escape },
648};
649
651 { .required = true, .type = FR_TYPE_STRING, .safe_for = LDAP_URI_SAFE_FOR, .will_escape = true, },
653};
654
655/** Produce canonical LDAP host URI for finding trunks
656 *
657 */
658static inline CC_HINT(always_inline)
659char *host_uri_canonify(request_t *request, LDAPURLDesc *url_parsed, fr_value_box_t *url_in)
660{
661 char *host;
662
663 LDAPURLDesc tmp_desc = {
664 .lud_scheme = url_parsed->lud_scheme,
665 .lud_host = url_parsed->lud_host,
666 .lud_port = url_parsed->lud_port,
667 .lud_scope = -1
668 };
669 host = ldap_url_desc2str(&tmp_desc);
670 if (unlikely(host == NULL)) REDEBUG("Invalid LDAP URL - %pV", url_in); \
671
672 return host;
673}
674
675/** Utility function for parsing LDAP URLs
676 *
677 * All LDAP xlat functions that work with LDAP URLs should call this function to parse the URL.
678 *
679 * @param[out] uri_parsed LDAP URL parsed. Must be freed with ldap_url_desc_free.
680 * @param[out] host_out host name to use for the query. Must be freed with ldap_mem_free
681 * if free_host_out is true.
682 * @param[out] free_host_out True if host_out should be freed.
683 * @param[in] request Request being processed.
684 * @param[in] host_default Default host to use if the URL does not specify a host.
685 * @param[in] uri_in URI to parse.
686 * @return
687 * - 0 on success.
688 * - -1 on failure.
689 */
690static int ldap_xlat_uri_parse(LDAPURLDesc **uri_parsed, char **host_out, bool *free_host_out,
691 request_t *request, char *host_default, fr_value_box_t *uri_in)
692{
693 fr_value_box_t *uri;
694 int ldap_url_ret;
695
696 *free_host_out = false;
697
698 if (fr_uri_escape_list(&uri_in->vb_group, ldap_uri_parts, NULL) < 0){
699 RPERROR("Failed to escape LDAP URI");
700 error:
701 *uri_parsed = NULL;
702 return -1;
703 }
704
705 /*
706 * Smush everything into the first URI box
707 */
708 uri = fr_value_box_list_head(&uri_in->vb_group);
709
710 if (fr_value_box_list_concat_in_place(uri, uri, &uri_in->vb_group,
711 FR_TYPE_STRING, FR_VALUE_BOX_LIST_FREE, true, SIZE_MAX) < 0) {
712 RPEDEBUG("Failed concatenating input");
713 goto error;
714 }
715
716 if (!ldap_is_ldap_url(uri->vb_strvalue)) {
717 REDEBUG("String passed does not look like an LDAP URL");
718 goto error;
719 }
720
721 ldap_url_ret = ldap_url_parse(uri->vb_strvalue, uri_parsed);
722 if (ldap_url_ret != LDAP_URL_SUCCESS){
723 RPEDEBUG("Parsing LDAP URL failed - %s", fr_ldap_url_err_to_str(ldap_url_ret));
724 goto error;
725 }
726
727 /*
728 * If the URL is <scheme>:/// the parsed host will be NULL - use config default
729 */
730 if (!(*uri_parsed)->lud_host) {
731 *host_out = host_default;
732 } else {
733 *host_out = host_uri_canonify(request, *uri_parsed, uri);
734 if (unlikely(*host_out == NULL)) {
735 ldap_free_urldesc(*uri_parsed);
736 *uri_parsed = NULL;
737 return -1;
738 }
739 *free_host_out = true;
740 }
741
742 return 0;
743}
744
745/** Expand an LDAP URL into a query, and return a string result from that query.
746 *
747 * @ingroup xlat_functions
748 */
750 xlat_ctx_t const *xctx,
751 request_t *request, fr_value_box_list_t *in)
752{
753 fr_ldap_thread_t *t = talloc_get_type_abort(xctx->mctx->thread, fr_ldap_thread_t);
754 fr_value_box_t *uri;
755 char *host;
756 bool free_host = false;
757 fr_ldap_config_t const *handle_config = t->config;
759 fr_ldap_query_t *query = NULL;
760
761 LDAPURLDesc *ldap_url;
762
763 XLAT_ARGS(in, &uri);
764
765 if (ldap_xlat_uri_parse(&ldap_url, &host, &free_host, request, handle_config->server, uri) < 0) return XLAT_ACTION_FAIL;
766
767 /*
768 * Nothing, empty string, "*" string, or got 2 things, die.
769 */
770 if (!ldap_url->lud_attrs || !ldap_url->lud_attrs[0] || !*ldap_url->lud_attrs[0] ||
771 (strcmp(ldap_url->lud_attrs[0], "*") == 0) || ldap_url->lud_attrs[1]) {
772 REDEBUG("Bad attributes list in LDAP URL. URL must specify exactly one attribute to retrieve");
773 ldap_free_urldesc(ldap_url);
774 return XLAT_ACTION_FAIL;
775 }
776
778 ldap_url->lud_dn, ldap_url->lud_scope, ldap_url->lud_filter,
779 (char const * const*)ldap_url->lud_attrs, NULL, NULL);
780 query->ldap_url = ldap_url; /* query destructor will free URL */
781
782 if (ldap_url->lud_exts) {
783 LDAPControl *serverctrls[LDAP_MAX_CONTROLS];
784 int i;
785
786 serverctrls[0] = NULL;
787
788 if (fr_ldap_parse_url_extensions(serverctrls, NUM_ELEMENTS(serverctrls),
789 query->ldap_url->lud_exts) < 0) {
790 RPERROR("Parsing URL extensions failed");
791 if (free_host) ldap_memfree(host);
792
793 query_error:
794 talloc_free(query);
795 return XLAT_ACTION_FAIL;
796 }
797
798 for (i = 0; i < LDAP_MAX_CONTROLS; i++) {
799 if (!serverctrls[i]) break;
800 query->serverctrls[i].control = serverctrls[i];
801 query->serverctrls[i].freeit = true;
802 }
803 }
804
805 /*
806 * Figure out what trunked connection we can use
807 * to communicate with the host.
808 *
809 * If free_host is true, we must free the host
810 * after deciding on a trunk connection as it
811 * was allocated by host_uri_canonify.
812 */
813 ttrunk = fr_thread_ldap_trunk_get(t, host, handle_config->admin_identity,
814 handle_config->admin_password, request, handle_config);
815 if (free_host) ldap_memfree(host);
816 if (!ttrunk) {
817 REDEBUG("Unable to get LDAP query for xlat");
818 goto query_error;
819 }
820
821 switch (trunk_request_enqueue(&query->treq, ttrunk->trunk, request, query, NULL)) {
822 case TRUNK_ENQUEUE_OK:
824 break;
825
826 default:
827 REDEBUG("Unable to enqueue LDAP query for xlat");
828 goto query_error;
829 }
830
831 if (fr_timer_in(query, unlang_interpret_event_list(request)->tl, &query->ev, handle_config->res_timeout,
832 false, ldap_query_timeout, query) < 0) {
833 REDEBUG("Unable to set timeout for LDAP query");
835 goto query_error;
836 }
837
839}
840
841/** User object lookup as part of group membership xlat
842 *
843 * Called if the ldap membership xlat is used and the user DN is not already known
844 */
846 request_t *request, void *uctx)
847{
848 ldap_group_xlat_ctx_t *xlat_ctx = talloc_get_type_abort(uctx, ldap_group_xlat_ctx_t);
849
850 if (xlat_ctx->env_data->user_filter.type == FR_TYPE_STRING) xlat_ctx->filter = &xlat_ctx->env_data->user_filter;
851
852 xlat_ctx->basedn = &xlat_ctx->env_data->user_base;
853
854 return rlm_ldap_find_user_async(xlat_ctx, xlat_ctx->inst, request, xlat_ctx->basedn, xlat_ctx->filter,
855 xlat_ctx->ttrunk, xlat_ctx->attrs, &xlat_ctx->query);
856}
857
858/** Cancel an in-progress query for the LDAP group membership xlat
859 *
860 */
861static void ldap_group_xlat_cancel(UNUSED request_t *request, UNUSED fr_signal_t action, void *uctx)
862{
863 ldap_group_xlat_ctx_t *xlat_ctx = talloc_get_type_abort(uctx, ldap_group_xlat_ctx_t);
864
865 if (!xlat_ctx->query || !xlat_ctx->query->treq) return;
866
868}
869
870#define REPEAT_LDAP_MEMBEROF_XLAT_RESULTS \
871 if (unlang_function_repeat_set(request, ldap_group_xlat_results) < 0) do { \
872 rcode = RLM_MODULE_FAIL; \
873 goto finish; \
874 } while (0)
875
876/** Run the state machine for the LDAP membership xlat
877 *
878 * This is called after each async lookup is completed
879 */
881 request_t *request, void *uctx)
882{
883 ldap_group_xlat_ctx_t *xlat_ctx = talloc_get_type_abort(uctx, ldap_group_xlat_ctx_t);
884 rlm_ldap_t const *inst = xlat_ctx->inst;
886
887 switch (xlat_ctx->status) {
889 if (!xlat_ctx->dn) xlat_ctx->dn = rlm_find_user_dn_cached(request);
891
892 if (inst->group.obj_membership_filter) {
897 }
898 }
900
902 if (xlat_ctx->found) {
903 rcode = RLM_MODULE_OK;
904 goto finish;
905 }
906
907 if (inst->group.userobj_membership_attr) {
912 }
913 }
915
917 if (xlat_ctx->found) rcode = RLM_MODULE_OK;
918 break;
919 }
920
921finish:
922 RETURN_MODULE_RCODE(rcode);
923}
924
925/** Process the results of evaluating LDAP group membership
926 *
927 */
928static xlat_action_t ldap_group_xlat_resume(TALLOC_CTX *ctx, fr_dcursor_t *out, xlat_ctx_t const *xctx,
929 UNUSED request_t *request, UNUSED fr_value_box_list_t *in)
930{
931 ldap_group_xlat_ctx_t *xlat_ctx = talloc_get_type_abort(xctx->rctx, ldap_group_xlat_ctx_t);
932 fr_value_box_t *vb;
933
935 vb->vb_bool = xlat_ctx->found;
937
938 return XLAT_ACTION_DONE;
939}
940
942 { .required = true, .concat = true, .type = FR_TYPE_STRING, .safe_for = LDAP_URI_SAFE_FOR },
944};
945
946/** Check for a user being in a LDAP group
947 *
948 * @ingroup xlat_functions
949 */
950static xlat_action_t ldap_group_xlat(TALLOC_CTX *ctx, fr_dcursor_t *out, xlat_ctx_t const *xctx,
951 request_t *request, fr_value_box_list_t *in)
952{
953 fr_value_box_t *vb = NULL, *group_vb = fr_value_box_list_pop_head(in);
955 fr_ldap_thread_t *t = talloc_get_type_abort(xctx->mctx->thread, fr_ldap_thread_t);
956 ldap_xlat_memberof_call_env_t *env_data = talloc_get_type_abort(xctx->env_data, ldap_xlat_memberof_call_env_t);
957 bool group_is_dn;
959
960 RDEBUG2("Searching for user in group \"%pV\"", group_vb);
961
962 if (group_vb->vb_length == 0) {
963 REDEBUG("Cannot do comparison (group name is empty)");
964 return XLAT_ACTION_FAIL;
965 }
966
967 group_is_dn = fr_ldap_util_is_dn(group_vb->vb_strvalue, group_vb->vb_length);
968 if (group_is_dn) {
969 char *norm;
970 size_t len;
971
972 MEM(norm = talloc_array(group_vb, char, talloc_array_length(group_vb->vb_strvalue)));
973 len = fr_ldap_util_normalise_dn(norm, group_vb->vb_strvalue);
974
975 /*
976 * Will clear existing buffer (i.e. group_vb->vb_strvalue)
977 */
978 fr_value_box_bstrdup_buffer_shallow(group_vb, group_vb, NULL, norm, group_vb->tainted);
979
980 /*
981 * Trim buffer to match normalised DN
982 */
983 fr_value_box_bstr_realloc(group_vb, NULL, group_vb, len);
984 }
985
986 if ((group_is_dn && inst->group.cacheable_dn) || (!group_is_dn && inst->group.cacheable_name)) {
987 rlm_rcode_t our_rcode;
988
989 rlm_ldap_check_cached(&our_rcode, inst, request, group_vb);
990 switch (our_rcode) {
992 RDEBUG2("User is not a member of \"%pV\"", group_vb);
993 return XLAT_ACTION_DONE;
994
995 case RLM_MODULE_OK:
996 MEM(vb = fr_value_box_alloc(ctx, FR_TYPE_BOOL, NULL));
997 vb->vb_bool = true;
999 return XLAT_ACTION_DONE;
1000
1001 /*
1002 * Fallback to dynamic search
1003 */
1004 default:
1005 break;
1006 }
1007 }
1008
1010
1012 .inst = inst,
1013 .group = group_vb,
1014 .dn = rlm_find_user_dn_cached(request),
1015 .attrs = { inst->group.userobj_membership_attr, NULL },
1016 .group_is_dn = group_is_dn,
1017 .env_data = env_data
1018 };
1019
1020 xlat_ctx->ttrunk = fr_thread_ldap_trunk_get(t, inst->handle_config.server, inst->handle_config.admin_identity,
1021 inst->handle_config.admin_password, request, &inst->handle_config);
1022
1023 if (!xlat_ctx->ttrunk) {
1024 REDEBUG("Unable to get LDAP trunk for group membership check");
1025 error:
1027 return XLAT_ACTION_FAIL;
1028 }
1029
1030 if (unlang_xlat_yield(request, ldap_group_xlat_resume, NULL, 0, xlat_ctx) != XLAT_ACTION_YIELD) goto error;
1031
1034 UNLANG_SUB_FRAME, xlat_ctx) < 0) goto error;
1035
1037}
1038
1045
1046/** Return whether evaluating the profile was successful
1047 *
1048 */
1050 UNUSED request_t *request, UNUSED fr_value_box_list_t *in)
1051{
1052 ldap_xlat_profile_ctx_t *xlat_ctx = talloc_get_type_abort(xctx->rctx, ldap_xlat_profile_ctx_t);
1053 fr_value_box_t *vb;
1054
1056 vb->vb_bool = (xlat_ctx->ret == LDAP_RESULT_SUCCESS) && (xlat_ctx->applied > 0);
1058
1059 return XLAT_ACTION_DONE;
1060}
1061
1063{
1064 if (to_free->url) {
1065 ldap_free_urldesc(to_free->url);
1066 to_free->url = NULL;
1067 }
1068 return 0;
1069}
1070
1071/** Expand an LDAP URL into a query, applying the results using the user update map.
1072 *
1073 * For fetching profiles by DN.
1074 *
1075 * @ingroup xlat_functions
1076 */
1078 xlat_ctx_t const *xctx,
1079 request_t *request, fr_value_box_list_t *in)
1080{
1082 fr_ldap_thread_t *t = talloc_get_type_abort(xctx->mctx->thread, fr_ldap_thread_t);
1083 ldap_xlat_profile_call_env_t *env_data = talloc_get_type_abort(xctx->env_data, ldap_xlat_profile_call_env_t);
1084 fr_value_box_t *uri_components, *uri;
1085 char *host_url, *host = NULL;
1086 fr_ldap_config_t const *handle_config = t->config;
1087 fr_ldap_thread_trunk_t *ttrunk;
1089
1090 int ldap_url_ret;
1091
1092 char const *dn;
1093 char const *filter;
1094 int scope;
1095
1096 bool is_dn;
1097
1098 XLAT_ARGS(in, &uri_components);
1099
1100 is_dn = (fr_uri_has_scheme(&uri_components->vb_group, ldap_uri_scheme_table, ldap_uri_scheme_table_len, -1) < 0);
1101
1102 /*
1103 * Apply different escaping rules based on whether the first
1104 * arg lookgs like a URI or a DN.
1105 */
1106 if (is_dn) {
1107 if (fr_uri_escape_list(&uri_components->vb_group, ldap_dn_parts, NULL) < 0) {
1108 RPERROR("Failed to escape LDAP profile DN");
1109 return XLAT_ACTION_FAIL;
1110 }
1111 } else {
1112 if (fr_uri_escape_list(&uri_components->vb_group, ldap_uri_parts, NULL) < 0) {
1113 RPERROR("Failed to escape LDAP profile URI");
1114 return XLAT_ACTION_FAIL;
1115 }
1116 }
1117
1118 /*
1119 * Smush everything into the first URI box
1120 */
1121 uri = fr_value_box_list_head(&uri_components->vb_group);
1122 if (fr_value_box_list_concat_in_place(uri, uri, &uri_components->vb_group,
1123 FR_TYPE_STRING, FR_VALUE_BOX_LIST_FREE, true, SIZE_MAX) < 0) {
1124 RPEDEBUG("Failed concatenating input");
1125 return XLAT_ACTION_FAIL;
1126 }
1127
1128 /*
1129 * Allocate a resumption context to store temporary resource and results
1130 */
1132 talloc_set_destructor(xlat_ctx, ldap_xlat_profile_ctx_free);
1133
1134 if (is_dn) {
1135 host_url = handle_config->server;
1136 dn = talloc_typed_strdup_buffer(xlat_ctx, uri->vb_strvalue);
1137 filter = env_data->profile_filter.vb_strvalue;
1138 scope = inst->profile.obj_scope;
1139 } else {
1140 ldap_url_ret = ldap_url_parse(uri->vb_strvalue, &xlat_ctx->url);
1141 if (ldap_url_ret != LDAP_URL_SUCCESS){
1142 RPEDEBUG("Parsing LDAP URL failed - %s", fr_ldap_url_err_to_str(ldap_url_ret));
1143 error:
1145 return XLAT_ACTION_FAIL;
1146 }
1147
1148 /*
1149 * The URL must specify a DN
1150 */
1151 if (!xlat_ctx->url->lud_dn) {
1152 REDEBUG("LDAP URI must specify a profile DN");
1153 goto error;
1154 }
1155
1156 dn = xlat_ctx->url->lud_dn;
1157 /*
1158 * Either we use the filter from the URL or we use the default filter
1159 * configured for profiles.
1160 */
1161 filter = xlat_ctx->url->lud_filter ? xlat_ctx->url->lud_filter : env_data->profile_filter.vb_strvalue;
1162
1163 /*
1164 * Determine if the URL includes a scope.
1165 */
1166 scope = xlat_ctx->url->lud_scope == LDAP_SCOPE_DEFAULT ? inst->profile.obj_scope : xlat_ctx->url->lud_scope;
1167
1168 /*
1169 * If the URL is <scheme>:/// the parsed host will be NULL - use config default
1170 */
1171 if (!xlat_ctx->url->lud_host) {
1172 host_url = handle_config->server;
1173 } else {
1174 host_url = host = host_uri_canonify(request, xlat_ctx->url, uri);
1175 if (unlikely(host_url == NULL)) goto error;
1176 }
1177 }
1178
1179 /*
1180 * Synchronous expansion of maps (fixme!)
1181 */
1182 if (fr_ldap_map_expand(xlat_ctx, &xlat_ctx->expanded, request, env_data->profile_map,
1183 inst->valuepair_attr, inst->profile.check_attr, inst->profile.fallthrough_attr) < 0) goto error;
1184 ttrunk = fr_thread_ldap_trunk_get(t, host_url, handle_config->admin_identity,
1185 handle_config->admin_password, request, handle_config);
1186 if (host) ldap_memfree(host);
1187 if (!ttrunk) {
1188 REDEBUG("Unable to get LDAP query for xlat");
1189 goto error;
1190 }
1191
1192 if (unlang_xlat_yield(request, ldap_profile_xlat_resume, NULL, 0, xlat_ctx) != XLAT_ACTION_YIELD) goto error;
1193
1194 /*
1195 * Pushes a frame onto the stack to retrieve and evaluate a profile
1196 */
1197 if (rlm_ldap_map_profile(&xlat_ctx->ret, &xlat_ctx->applied, inst, request, ttrunk, dn,
1198 scope, filter, &xlat_ctx->expanded) < 0) goto error;
1199
1201}
1202
1203/*
1204 * Verify the result of the map.
1205 */
1206static int ldap_map_verify(CONF_SECTION *cs, UNUSED void const *mod_inst, UNUSED void *proc_inst,
1207 tmpl_t const *src, UNUSED map_list_t const *maps)
1208{
1209 if (!src) {
1210 cf_log_err(cs, "Missing LDAP URI");
1211
1212 return -1;
1213 }
1214
1215 return 0;
1216}
1217
1218/** Process the results of an LDAP map query
1219 *
1220 * @param[out] p_result Result of applying the map.
1221 * @param[in] priority Unused.
1222 * @param[in] request Current request.
1223 * @param[in] uctx Map context.
1224 * @return One of UNLANG_ACTION_*
1225 */
1226static unlang_action_t mod_map_resume(rlm_rcode_t *p_result, UNUSED int *priority, request_t *request, void *uctx)
1227{
1228 ldap_map_ctx_t *map_ctx = talloc_get_type_abort(uctx, ldap_map_ctx_t);
1229 fr_ldap_query_t *query = map_ctx->query;
1230 fr_ldap_map_exp_t *expanded = &map_ctx->expanded;
1232 LDAPMessage *entry;
1233 map_t const *map;
1234
1235 switch (query->ret) {
1237 rcode = RLM_MODULE_UPDATED;
1238 break;
1239
1241 case LDAP_RESULT_BAD_DN:
1242 goto finish;
1243
1245 goto finish;
1246
1247 default:
1248 rcode = RLM_MODULE_FAIL;
1249 goto finish;
1250 }
1251
1252 for (entry = ldap_first_entry(query->ldap_conn->handle, query->result);
1253 entry;
1254 entry = ldap_next_entry(query->ldap_conn->handle, entry)) {
1255 char *dn = NULL;
1256 int i;
1257
1258 if (RDEBUG_ENABLED2) {
1259 dn = ldap_get_dn(query->ldap_conn->handle, entry);
1260 RDEBUG2("Processing \"%s\"", dn);
1261 }
1262
1263 RINDENT();
1264 for (map = map_list_head(map_ctx->maps), i = 0;
1265 map != NULL;
1266 map = map_list_next(map_ctx->maps, map), i++) {
1267 int ret;
1268 fr_ldap_result_t attr;
1269
1270 attr.values = ldap_get_values_len(query->ldap_conn->handle, entry, expanded->attrs[i]);
1271 if (!attr.values) {
1272 /*
1273 * Many LDAP directories don't expose the DN of
1274 * the object as an attribute, so we need this
1275 * hack, to allow the user to retrieve it.
1276 */
1277 if (strcmp(LDAP_VIRTUAL_DN_ATTR, expanded->attrs[i]) == 0) {
1278 struct berval value;
1279 struct berval *values[2] = { &value, NULL };
1280
1281 if (!dn) dn = ldap_get_dn(query->ldap_conn->handle, entry);
1282 value.bv_val = dn;
1283 value.bv_len = strlen(dn);
1284
1285 attr.values = values;
1286 attr.count = 1;
1287
1288 ret = map_to_request(request, map, fr_ldap_map_getvalue, &attr);
1289 if (ret == -1) {
1290 rcode = RLM_MODULE_FAIL;
1291 ldap_memfree(dn);
1292 goto finish;
1293 }
1294 continue;
1295 }
1296
1297 RDEBUG3("Attribute \"%s\" not found in LDAP object", expanded->attrs[i]);
1298
1299 continue;
1300 }
1301 attr.count = ldap_count_values_len(attr.values);
1302
1303 ret = map_to_request(request, map, fr_ldap_map_getvalue, &attr);
1304 ldap_value_free_len(attr.values);
1305 if (ret == -1) {
1306 rcode = RLM_MODULE_FAIL;
1307 ldap_memfree(dn);
1308 goto finish;
1309 }
1310 }
1311 ldap_memfree(dn);
1312 REXDENT();
1313 }
1314
1315finish:
1316 RETURN_MODULE_RCODE(rcode);
1317}
1318
1319/** Ensure map context is properly cleared up
1320 *
1321 */
1322static int map_ctx_free(ldap_map_ctx_t *map_ctx)
1323{
1324 int i = 0;
1325 talloc_free(map_ctx->expanded.ctx);
1326 ldap_free_urldesc(map_ctx->ldap_url);
1327 while ((i < LDAP_MAX_CONTROLS) && map_ctx->serverctrls[i]) {
1328 ldap_control_free(map_ctx->serverctrls[i]);
1329 i++;
1330 }
1331 return (0);
1332}
1333
1334/** Perform a search and map the result of the search to server attributes
1335 *
1336 * Unlike LDAP xlat, this can be used to process attributes from multiple entries.
1337 *
1338 * @todo For xlat expansions we need to parse the raw URL first, and then apply
1339 * different escape functions to the different parts.
1340 *
1341 * @param[out] p_result Result of map expansion:
1342 * - #RLM_MODULE_NOOP no rows were returned.
1343 * - #RLM_MODULE_UPDATED if one or more #fr_pair_t were added to the #request_t.
1344 * - #RLM_MODULE_FAIL if an error occurred.
1345 * @param[in] mod_inst #rlm_ldap_t
1346 * @param[in] proc_inst unused.
1347 * @param[in,out] request The current request.
1348 * @param[in] url LDAP url specifying base DN and filter.
1349 * @param[in] maps Head of the map list.
1350 * @return UNLANG_ACTION_CALCULATE_RESULT
1351 */
1352static unlang_action_t mod_map_proc(rlm_rcode_t *p_result, void const *mod_inst, UNUSED void *proc_inst, request_t *request,
1353 fr_value_box_list_t *url, map_list_t const *maps)
1354{
1356 fr_ldap_thread_t *thread = talloc_get_type_abort(module_thread(inst->mi)->data, fr_ldap_thread_t);
1357
1358 LDAPURLDesc *ldap_url;
1359 int ldap_url_ret;
1360 fr_ldap_thread_trunk_t *ttrunk;
1361
1362 fr_value_box_t *url_head;
1363 ldap_map_ctx_t *map_ctx;
1364 char *host_url, *host = NULL;
1365
1366 if (fr_uri_escape_list(url, ldap_uri_parts, NULL) < 0) {
1367 RPERROR("Failed to escape LDAP map URI");
1369 }
1370
1371 url_head = fr_value_box_list_head(url);
1372 if (!url_head) {
1373 REDEBUG("LDAP URL cannot be empty");
1375 }
1376
1377 if (fr_value_box_list_concat_in_place(url_head, url_head, url, FR_TYPE_STRING,
1378 FR_VALUE_BOX_LIST_FREE, true, SIZE_MAX) < 0) {
1379 RPEDEBUG("Failed concatenating input");
1381 }
1382
1383 if (!ldap_is_ldap_url(url_head->vb_strvalue)) {
1384 REDEBUG("Map query string does not look like a valid LDAP URI");
1386 }
1387
1388 MEM(map_ctx = talloc_zero(unlang_interpret_frame_talloc_ctx(request), ldap_map_ctx_t));
1389 talloc_set_destructor(map_ctx, map_ctx_free);
1390 map_ctx->maps = maps;
1391
1392 ldap_url_ret = ldap_url_parse(url_head->vb_strvalue, &map_ctx->ldap_url);
1393 if (ldap_url_ret != LDAP_URL_SUCCESS){
1394 RPEDEBUG("Parsing LDAP URL failed - %s", fr_ldap_url_err_to_str(ldap_url_ret));
1395 fail:
1396 talloc_free(map_ctx);
1398 }
1399 ldap_url = map_ctx->ldap_url;
1400
1401 if (ldap_url->lud_exts) {
1403 ldap_url->lud_exts) < 0) {
1404 RPERROR("Parsing URL extensions failed");
1405 goto fail;
1406 }
1407 }
1408
1409 /*
1410 * Expand the RHS of the maps to get the name of the attributes.
1411 */
1412 if (fr_ldap_map_expand(map_ctx, &map_ctx->expanded, request, maps, NULL, NULL, NULL) < 0) goto fail;
1413
1414 /*
1415 * If the URL is <scheme>:/// the parsed host will be NULL - use config default
1416 */
1417 if (!ldap_url->lud_host) {
1418 host_url = inst->handle_config.server;
1419 } else {
1420 host_url = host = host_uri_canonify(request, ldap_url, url_head);
1421 if (unlikely(host_url == NULL)) goto fail;
1422 }
1423
1424 ttrunk = fr_thread_ldap_trunk_get(thread, host_url, inst->handle_config.admin_identity,
1425 inst->handle_config.admin_password, request, &inst->handle_config);
1426 if (host) ldap_memfree(host);
1427 if (!ttrunk) goto fail;
1428
1429 if (unlang_function_push(request, NULL, mod_map_resume, NULL, 0,
1430 UNLANG_SUB_FRAME, map_ctx) != UNLANG_ACTION_PUSHED_CHILD) goto fail;
1431
1432 return fr_ldap_trunk_search(map_ctx, &map_ctx->query, request, ttrunk, ldap_url->lud_dn,
1433 ldap_url->lud_scope, ldap_url->lud_filter, map_ctx->expanded.attrs,
1434 map_ctx->serverctrls, NULL);
1435}
1436
1437static unlang_action_t CC_HINT(nonnull) mod_authenticate(rlm_rcode_t *p_result, module_ctx_t const *mctx, request_t *request)
1438{
1440 fr_ldap_thread_t *thread = talloc_get_type_abort(module_thread(inst->mi)->data, fr_ldap_thread_t);
1441 ldap_auth_ctx_t *auth_ctx;
1442 ldap_auth_call_env_t *call_env = talloc_get_type_abort(mctx->env_data, ldap_auth_call_env_t);
1443
1444 if (call_env->password.type != FR_TYPE_STRING) {
1445 RWDEBUG("You have set \"Auth-Type := LDAP\" somewhere");
1446 RWDEBUG("without checking if %s is present", call_env->password_tmpl->name);
1447 RWDEBUG("*********************************************");
1448 RWDEBUG("* THAT CONFIGURATION IS WRONG. DELETE IT. ");
1449 RWDEBUG("* YOU ARE PREVENTING THE SERVER FROM WORKING");
1450 RWDEBUG("*********************************************");
1451
1452 REDEBUG("Attribute \"%s\" is required for authentication", call_env->password_tmpl->name);
1454 }
1455
1456 auth_ctx = talloc(unlang_interpret_frame_talloc_ctx(request), ldap_auth_ctx_t);
1457 *auth_ctx = (ldap_auth_ctx_t){
1458 .password = call_env->password.vb_strvalue,
1459 .thread = thread,
1460 .inst = inst,
1461 .call_env = call_env
1462 };
1463
1464 /*
1465 * Find the user's DN
1466 */
1467 auth_ctx->dn = rlm_find_user_dn_cached(request);
1468
1469 /*
1470 * The DN is required for non-SASL auth
1471 */
1472 if (!auth_ctx->dn && (call_env->user_sasl_mech.type != FR_TYPE_STRING)) {
1473 REDEBUG("No DN found for authentication. Populate control.%s with the DN to use in authentication.",
1474 attr_ldap_userdn->name);
1475 REDEBUG("You should call %s in the recv section and check its return.", inst->mi->name);
1476 talloc_free(auth_ctx);
1478 }
1479
1480 /*
1481 * Log the password
1482 */
1483 if (RDEBUG_ENABLED3) {
1484 RDEBUG("Login attempt with password \"%pV\"", &call_env->password);
1485 } else {
1486 RDEBUG2("Login attempt with password");
1487 }
1488
1489 /*
1490 * SASL bind auth will have the mech set.
1491 */
1492 if (auth_ctx->call_env->user_sasl_mech.type == FR_TYPE_STRING) {
1493#ifdef WITH_SASL
1494 RDEBUG2("Login attempt using identity \"%pV\"", &call_env->user_sasl_authname);
1495
1496 return fr_ldap_sasl_bind_auth_async(request, auth_ctx->thread, call_env->user_sasl_mech.vb_strvalue,
1497 call_env->user_sasl_authname.vb_strvalue,
1498 auth_ctx->password, call_env->user_sasl_proxy.vb_strvalue,
1499 call_env->user_sasl_realm.vb_strvalue);
1500#else
1501 RDEBUG("Configuration item 'sasl.mech' is not supported. "
1502 "The linked version of libldap does not provide ldap_sasl_bind( function");
1504#endif
1505 }
1506
1507 RDEBUG2("Login attempt as \"%s\"", auth_ctx->dn);
1508
1509 return fr_ldap_bind_auth_async(request, auth_ctx->thread, auth_ctx->dn, auth_ctx->password);
1510}
1511
1512/** Start LDAP authorization with async lookup of user DN
1513 *
1514 */
1516 request_t *request, void *uctx)
1517{
1518 ldap_autz_ctx_t *autz_ctx = talloc_get_type_abort(uctx, ldap_autz_ctx_t);
1519 return rlm_ldap_find_user_async(autz_ctx, autz_ctx->inst, request, &autz_ctx->call_env->user_base,
1520 &autz_ctx->call_env->user_filter, autz_ctx->ttrunk, autz_ctx->expanded.attrs,
1521 &autz_ctx->query);
1522}
1523
1524#define REPEAT_MOD_AUTHORIZE_RESUME \
1525 if (unlang_function_repeat_set(request, mod_authorize_resume) < 0) do { \
1526 rcode = RLM_MODULE_FAIL; \
1527 goto finish; \
1528 } while (0)
1529
1530/** Resume function called after each potential yield in LDAP authorization
1531 *
1532 * Some operations may or may not yield. E.g. if group membership is
1533 * read from an attribute returned with the user object and is already
1534 * in the correct form, that will not yield.
1535 * Hence, each state may fall through to the next.
1536 *
1537 * @param p_result Result of current authorization.
1538 * @param priority Unused.
1539 * @param request Current request.
1540 * @param uctx Current authorization context.
1541 * @return One of the RLM_MODULE_* values.
1542 */
1543static unlang_action_t mod_authorize_resume(rlm_rcode_t *p_result, UNUSED int *priority, request_t *request, void *uctx)
1544{
1545 ldap_autz_ctx_t *autz_ctx = talloc_get_type_abort(uctx, ldap_autz_ctx_t);
1547 ldap_autz_call_env_t *call_env = talloc_get_type_abort(autz_ctx->call_env, ldap_autz_call_env_t);
1548 int ldap_errno;
1549 rlm_rcode_t rcode = RLM_MODULE_OK;
1550 LDAP *handle = fr_ldap_handle_thread_local();
1551
1552 /*
1553 * If a previous async call returned one of the "failure" results just return.
1554 */
1555 switch (*p_result) {
1556 case RLM_MODULE_REJECT:
1557 case RLM_MODULE_FAIL:
1558 case RLM_MODULE_HANDLED:
1559 case RLM_MODULE_INVALID:
1561 rcode = *p_result;
1562 goto finish;
1563
1564 default:
1565 break;
1566 }
1567
1568 switch (autz_ctx->status) {
1569 case LDAP_AUTZ_FIND:
1570 /*
1571 * If a user entry has been found the current rcode will be OK
1572 */
1573 if (*p_result != RLM_MODULE_OK) return UNLANG_ACTION_CALCULATE_RESULT;
1574
1575 autz_ctx->entry = ldap_first_entry(handle, autz_ctx->query->result);
1576 if (!autz_ctx->entry) {
1577 ldap_get_option(handle, LDAP_OPT_RESULT_CODE, &ldap_errno);
1578 REDEBUG("Failed retrieving entry: %s", ldap_err2string(ldap_errno));
1579
1580 goto finish;
1581 }
1582
1583 /*
1584 * Check for access.
1585 */
1586 if (inst->user.obj_access_attr) {
1587 autz_ctx->access_state = rlm_ldap_check_access(inst, request, autz_ctx->entry);
1588 switch (autz_ctx->access_state) {
1590 break;
1591
1593 if (inst->group.skip_on_suspend) goto post_group;
1594 break;
1595
1597 rcode = RLM_MODULE_DISALLOW;
1598 goto finish;
1599 }
1600 }
1601
1602 /*
1603 * Check if we need to cache group memberships
1604 */
1605 if ((inst->group.cacheable_dn || inst->group.cacheable_name) && (inst->group.userobj_membership_attr)) {
1607 if (rlm_ldap_cacheable_userobj(&rcode, request, autz_ctx,
1608 inst->group.userobj_membership_attr) == UNLANG_ACTION_PUSHED_CHILD) {
1609 autz_ctx->status = LDAP_AUTZ_GROUP;
1611 }
1612 if (rcode != RLM_MODULE_OK) goto finish;
1613 }
1615
1616 case LDAP_AUTZ_GROUP:
1617 if (inst->group.cacheable_dn || inst->group.cacheable_name) {
1619 if (rlm_ldap_cacheable_groupobj(&rcode, request, autz_ctx) == UNLANG_ACTION_PUSHED_CHILD) {
1620 autz_ctx->status = LDAP_AUTZ_POST_GROUP;
1622 }
1623 if (rcode != RLM_MODULE_OK) goto finish;
1624 }
1626
1628 post_group:
1629#ifdef WITH_EDIR
1630 /*
1631 * We already have a Password.Cleartext. Skip edir.
1632 */
1633 if (fr_pair_find_by_da_nested(&request->control_pairs, NULL, attr_cleartext_password)) goto skip_edir;
1634
1635 /*
1636 * Retrieve Universal Password if we use eDirectory
1637 */
1638 if (inst->edir) {
1639 autz_ctx->dn = rlm_find_user_dn_cached(request);
1640
1641 /*
1642 * Retrieve universal password
1643 */
1645 autz_ctx->status = LDAP_AUTZ_EDIR_BIND;
1646 return fr_ldap_edir_get_password(request, autz_ctx->dn, autz_ctx->ttrunk,
1648 }
1650
1651 case LDAP_AUTZ_EDIR_BIND:
1652 if (inst->edir && inst->edir_autz) {
1653 fr_pair_t *password = fr_pair_find_by_da(&request->control_pairs,
1655 fr_ldap_thread_t *thread = talloc_get_type_abort(module_thread(inst->mi)->data,
1657
1658 if (!password) {
1659 REDEBUG("Failed to find control.Password.Cleartext");
1660 rcode = RLM_MODULE_FAIL;
1661 goto finish;
1662 }
1663
1664 RDEBUG2("Binding as %s for eDirectory authorization checks", autz_ctx->dn);
1665
1666 /*
1667 * Bind as the user
1668 */
1670 autz_ctx->status = LDAP_AUTZ_POST_EDIR;
1671 return fr_ldap_bind_auth_async(request, thread, autz_ctx->dn, password->vp_strvalue);
1672 }
1673 goto skip_edir;
1674
1675 case LDAP_AUTZ_POST_EDIR:
1676 {
1677 /*
1678 * The result of the eDirectory user bind will be in p_result.
1679 * Anything other than RLM_MODULE_OK is a failure.
1680 */
1681 if (*p_result != RLM_MODULE_OK) {
1682 rcode = *p_result;
1683 goto finish;
1684 }
1685
1686 }
1688
1689#endif
1690 case LDAP_AUTZ_MAP:
1691#ifdef WITH_EDIR
1692 skip_edir:
1693#endif
1694 if (!map_list_empty(call_env->user_map) || inst->valuepair_attr) {
1695 RDEBUG2("Processing user attributes");
1696 RINDENT();
1697 if (fr_ldap_map_do(request, NULL, inst->valuepair_attr,
1698 &autz_ctx->expanded, autz_ctx->entry) > 0) rcode = RLM_MODULE_UPDATED;
1699 REXDENT();
1700 rlm_ldap_check_reply(request, inst, autz_ctx->dlinst->name, call_env->expect_password->vb_bool, autz_ctx->ttrunk);
1701 }
1703
1705 /*
1706 * Apply ONE user profile, or a default user profile.
1707 */
1708 if (call_env->default_profile.type == FR_TYPE_STRING) {
1709 unlang_action_t ret;
1710
1712 ret = rlm_ldap_map_profile(NULL, NULL, inst, request, autz_ctx->ttrunk, autz_ctx->profile_value,
1713 inst->profile.obj_scope, call_env->default_profile.vb_strvalue, &autz_ctx->expanded);
1714 switch (ret) {
1715 case UNLANG_ACTION_FAIL:
1716 rcode = RLM_MODULE_FAIL;
1717 goto finish;
1718
1722
1723 default:
1724 break;
1725 }
1726 }
1728
1730 /*
1731 * Did we jump back her after applying the default profile?
1732 */
1733 if (autz_ctx->status == LDAP_AUTZ_POST_DEFAULT_PROFILE) {
1734 rcode = RLM_MODULE_UPDATED;
1735 }
1736 /*
1737 * Apply a SET of user profiles.
1738 */
1739 switch (autz_ctx->access_state) {
1741 if (inst->profile.attr) {
1742 int count;
1743
1744 autz_ctx->profile_values = ldap_get_values_len(handle, autz_ctx->entry, inst->profile.attr);
1745 count = ldap_count_values_len(autz_ctx->profile_values);
1746 if (count > 0) {
1747 RDEBUG2("Processing %i profile(s) found in attribute \"%s\"", count, inst->profile.attr);
1748 if (RDEBUG_ENABLED3) {
1749 for (struct berval **bv_p = autz_ctx->profile_values; *bv_p; bv_p++) {
1750 RDEBUG3("Will evaluate profile with DN \"%pV\"", fr_box_strvalue_len((*bv_p)->bv_val, (*bv_p)->bv_len));
1751 }
1752 }
1753 } else {
1754 RDEBUG2("No profile(s) found in attribute \"%s\"", inst->profile.attr);
1755 }
1756 }
1757 break;
1758
1760 if (inst->profile.attr_suspend) {
1761 int count;
1762
1763 autz_ctx->profile_values = ldap_get_values_len(handle, autz_ctx->entry, inst->profile.attr_suspend);
1764 count = ldap_count_values_len(autz_ctx->profile_values);
1765 if (count > 0) {
1766 RDEBUG2("Processing %i suspension profile(s) found in attribute \"%s\"", count, inst->profile.attr_suspend);
1767 if (RDEBUG_ENABLED3) {
1768 for (struct berval **bv_p = autz_ctx->profile_values; *bv_p; bv_p++) {
1769 RDEBUG3("Will evaluate suspenension profile with DN \"%pV\"",
1770 fr_box_strvalue_len((*bv_p)->bv_val, (*bv_p)->bv_len));
1771 }
1772 }
1773 } else {
1774 RDEBUG2("No suspension profile(s) found in attribute \"%s\"", inst->profile.attr_suspend);
1775 }
1776 }
1777 break;
1778
1780 break;
1781 }
1782
1784
1786 /*
1787 * After each profile has been applied, execution will restart here.
1788 * Start by clearing the previously used value.
1789 */
1790 if (autz_ctx->profile_value) {
1791 TALLOC_FREE(autz_ctx->profile_value);
1792 rcode = RLM_MODULE_UPDATED; /* We're back here after applying a profile successfully */
1793 }
1794
1795 if (autz_ctx->profile_values && autz_ctx->profile_values[autz_ctx->value_idx]) {
1796 unlang_action_t ret;
1797
1798 autz_ctx->profile_value = fr_ldap_berval_to_string(autz_ctx, autz_ctx->profile_values[autz_ctx->value_idx++]);
1800 ret = rlm_ldap_map_profile(NULL, NULL, inst, request, autz_ctx->ttrunk, autz_ctx->profile_value,
1801 inst->profile.obj_scope, autz_ctx->call_env->profile_filter.vb_strvalue, &autz_ctx->expanded);
1802 switch (ret) {
1803 case UNLANG_ACTION_FAIL:
1804 rcode = RLM_MODULE_FAIL;
1805 goto finish;
1806
1808 autz_ctx->status = LDAP_AUTZ_USER_PROFILE;
1810
1811 default:
1812 break;
1813 }
1814 }
1815 break;
1816 }
1817
1818finish:
1819 talloc_free(autz_ctx);
1820
1821 RETURN_MODULE_RCODE(rcode);
1822}
1823
1824/** Clear up when cancelling a mod_authorize call
1825 *
1826 */
1827static void mod_authorize_cancel(UNUSED request_t *request, UNUSED fr_signal_t action, void *uctx)
1828{
1829 ldap_autz_ctx_t *autz_ctx = talloc_get_type_abort(uctx, ldap_autz_ctx_t);
1830
1831 if (autz_ctx->query && autz_ctx->query->treq) trunk_request_signal_cancel(autz_ctx->query->treq);
1832}
1833
1834/** Ensure authorization context is properly cleared up
1835 *
1836 */
1837static int autz_ctx_free(ldap_autz_ctx_t *autz_ctx)
1838{
1839 talloc_free(autz_ctx->expanded.ctx);
1840 if (autz_ctx->profile_values) ldap_value_free_len(autz_ctx->profile_values);
1841 return 0;
1842}
1843
1844static unlang_action_t CC_HINT(nonnull) mod_authorize(rlm_rcode_t *p_result, module_ctx_t const *mctx, request_t *request)
1845{
1847 fr_ldap_thread_t *thread = talloc_get_type_abort(module_thread(inst->mi)->data, fr_ldap_thread_t);
1848 ldap_autz_ctx_t *autz_ctx;
1849 fr_ldap_map_exp_t *expanded;
1850 ldap_autz_call_env_t *call_env = talloc_get_type_abort(mctx->env_data, ldap_autz_call_env_t);
1851
1852 MEM(autz_ctx = talloc_zero(unlang_interpret_frame_talloc_ctx(request), ldap_autz_ctx_t));
1853 talloc_set_destructor(autz_ctx, autz_ctx_free);
1854 expanded = &autz_ctx->expanded;
1855
1856 /*
1857 * Don't be tempted to add a check for User-Name or
1858 * User-Password here. LDAP authorization can be used
1859 * for many things besides searching for users.
1860 */
1861 if (fr_ldap_map_expand(autz_ctx, expanded, request, call_env->user_map, inst->valuepair_attr,
1862 inst->profile.check_attr, inst->profile.fallthrough_attr) < 0) {
1863 fail:
1864 talloc_free(autz_ctx);
1866 }
1867
1868 autz_ctx->ttrunk = fr_thread_ldap_trunk_get(thread, inst->handle_config.server, inst->handle_config.admin_identity,
1869 inst->handle_config.admin_password, request, &inst->handle_config);
1870 if (!autz_ctx->ttrunk) goto fail;
1871
1872#define CHECK_EXPANDED_SPACE(_expanded) fr_assert((size_t)_expanded->count < (NUM_ELEMENTS(_expanded->attrs) - 1));
1873
1874 /*
1875 * Add any additional attributes we need for checking access, memberships, and profiles
1876 */
1877 if (inst->user.obj_access_attr) {
1878 CHECK_EXPANDED_SPACE(expanded);
1879 expanded->attrs[expanded->count++] = inst->user.obj_access_attr;
1880 }
1881
1882 if (inst->group.userobj_membership_attr && (inst->group.cacheable_dn || inst->group.cacheable_name)) {
1883 CHECK_EXPANDED_SPACE(expanded);
1884 expanded->attrs[expanded->count++] = inst->group.userobj_membership_attr;
1885 }
1886
1887 if (inst->profile.attr) {
1888 CHECK_EXPANDED_SPACE(expanded);
1889 expanded->attrs[expanded->count++] = inst->profile.attr;
1890 }
1891
1892 if (inst->profile.attr_suspend) {
1893 CHECK_EXPANDED_SPACE(expanded);
1894 expanded->attrs[expanded->count++] = inst->profile.attr_suspend;
1895 }
1896 expanded->attrs[expanded->count] = NULL;
1897
1898 autz_ctx->dlinst = mctx->mi;
1899 autz_ctx->inst = inst;
1900 autz_ctx->call_env = call_env;
1901 autz_ctx->status = LDAP_AUTZ_FIND;
1902
1905
1907}
1908
1909/** Perform async lookup of user DN if required for user modification
1910 *
1911 */
1913 request_t *request, void *uctx)
1914{
1915 ldap_user_modify_ctx_t *usermod_ctx = talloc_get_type_abort(uctx, ldap_user_modify_ctx_t);
1916
1917 return rlm_ldap_find_user_async(usermod_ctx, usermod_ctx->inst, request, &usermod_ctx->call_env->user_base,
1918 &usermod_ctx->call_env->user_filter, usermod_ctx->ttrunk, NULL, NULL);
1919}
1920
1921/** Cancel an in progress user modification.
1922 *
1923 */
1924static void user_modify_cancel(UNUSED request_t *request, UNUSED fr_signal_t action, void *uctx)
1925{
1926 ldap_user_modify_ctx_t *usermod_ctx = talloc_get_type_abort(uctx, ldap_user_modify_ctx_t);
1927
1928 if (!usermod_ctx->query || !usermod_ctx->query->treq) return;
1929
1930 trunk_request_signal_cancel(usermod_ctx->query->treq);
1931}
1932
1933/** Handle results of user modification.
1934 *
1935 */
1936static unlang_action_t user_modify_final(rlm_rcode_t *p_result, UNUSED int *priority,
1937 request_t *request, void *uctx)
1938{
1939 ldap_user_modify_ctx_t *usermod_ctx = talloc_get_type_abort(uctx, ldap_user_modify_ctx_t);
1940 fr_ldap_query_t *query = usermod_ctx->query;
1941 rlm_rcode_t rcode = RLM_MODULE_OK;
1942
1943 switch (query->ret) {
1945 break;
1946
1948 case LDAP_RESULT_BAD_DN:
1949 RDEBUG2("User object \"%s\" not modified", usermod_ctx->dn);
1950 rcode = RLM_MODULE_INVALID;
1951 break;
1952
1954 rcode = RLM_MODULE_TIMEOUT;
1955 break;
1956
1957 default:
1958 rcode = RLM_MODULE_FAIL;
1959 break;
1960 }
1961
1962 talloc_free(usermod_ctx);
1963 RETURN_MODULE_RCODE(rcode);
1964}
1965
1967 request_t *request, void *uctx)
1968{
1969 ldap_user_modify_ctx_t *usermod_ctx = talloc_get_type_abort(uctx, ldap_user_modify_ctx_t);
1970 ldap_usermod_call_env_t *call_env = usermod_ctx->call_env;
1971 LDAPMod **modify;
1972 ldap_mod_tmpl_t *mod;
1973 fr_value_box_t *vb = NULL;
1974 int mod_no = usermod_ctx->expanded_mods, i = 0;
1975 struct berval **value_refs;
1976 struct berval *values;
1977
1978 mod = call_env->mod[usermod_ctx->current_mod];
1979
1980 /*
1981 * If the tmpl produced no boxes, skip
1982 */
1983 if ((mod->op != T_OP_CMP_FALSE) && (fr_value_box_list_num_elements(&usermod_ctx->expanded) == 0)) {
1984 RDEBUG2("Expansion \"%s\" produced no value, skipping attribute \"%s\"", mod->tmpl->name, mod->attr);
1985 goto next;
1986 }
1987
1988 switch (mod->op) {
1989 /*
1990 * T_OP_EQ is *NOT* supported, it is impossible to
1991 * support because of the lack of transactions in LDAP
1992 *
1993 * To allow for binary data, all data is provided as berval which
1994 * requires the operation to be logical ORed with LDAP_MOD_BVALUES
1995 */
1996 case T_OP_ADD_EQ:
1997 usermod_ctx->mod_s[mod_no].mod_op = LDAP_MOD_ADD | LDAP_MOD_BVALUES;
1998 break;
1999
2000 case T_OP_SET:
2001 usermod_ctx->mod_s[mod_no].mod_op = LDAP_MOD_REPLACE | LDAP_MOD_BVALUES;
2002 break;
2003
2004 case T_OP_SUB_EQ:
2005 case T_OP_CMP_FALSE:
2006 usermod_ctx->mod_s[mod_no].mod_op = LDAP_MOD_DELETE | LDAP_MOD_BVALUES;
2007 break;
2008
2009 case T_OP_INCRM:
2010 usermod_ctx->mod_s[mod_no].mod_op = LDAP_MOD_INCREMENT | LDAP_MOD_BVALUES;
2011 break;
2012
2013 default:
2014 REDEBUG("Operator '%s' is not supported for LDAP modify operations",
2015 fr_table_str_by_value(fr_tokens_table, mod->op, "<INVALID>"));
2016
2018 }
2019
2020 if (mod->op == T_OP_CMP_FALSE) {
2021 MEM(value_refs = talloc_zero_array(usermod_ctx, struct berval *, 1));
2022 } else {
2023 MEM(value_refs = talloc_zero_array(usermod_ctx, struct berval *,
2024 fr_value_box_list_num_elements(&usermod_ctx->expanded) + 1));
2025 MEM(values = talloc_zero_array(usermod_ctx, struct berval,
2026 fr_value_box_list_num_elements(&usermod_ctx->expanded)));
2027 while ((vb = fr_value_box_list_pop_head(&usermod_ctx->expanded))) {
2028 switch (vb->type) {
2029 case FR_TYPE_OCTETS:
2030 if (vb->vb_length == 0) continue;
2031 memcpy(&values[i].bv_val, &vb->vb_octets, sizeof(values[i].bv_val));
2032 values[i].bv_len = vb->vb_length;
2033 break;
2034
2035 case FR_TYPE_STRING:
2036 populate_string:
2037 if (vb->vb_length == 0) continue;
2038 memcpy(&values[i].bv_val, &vb->vb_strvalue, sizeof(values[i].bv_val));
2039 values[i].bv_len = vb->vb_length;
2040 break;
2041
2042 case FR_TYPE_GROUP:
2043 {
2044 fr_value_box_t *vb_head = fr_value_box_list_head(&vb->vb_group);
2045 if (fr_value_box_list_concat_in_place(vb_head, vb_head, &vb->vb_group, FR_TYPE_STRING,
2046 FR_VALUE_BOX_LIST_FREE, true, SIZE_MAX) < 0) {
2047 RPEDEBUG("Failed concatenating update value");
2049 }
2050 vb = vb_head;
2051 goto populate_string;
2052 }
2053
2054 case FR_TYPE_FIXED_SIZE:
2055 if (fr_value_box_cast_in_place(vb, vb, FR_TYPE_STRING, NULL) < 0) {
2056 RPEDEBUG("Failed casting update value");
2058 }
2059 goto populate_string;
2060
2061 default:
2062 fr_assert(0);
2063
2064 }
2065 value_refs[i] = &values[i];
2066 i++;
2067 }
2068 if (i == 0) {
2069 RDEBUG2("Expansion \"%s\" produced zero length value, skipping attribute \"%s\"", mod->tmpl->name, mod->attr);
2070 goto next;
2071 }
2072 }
2073
2074 /*
2075 * Now everything is evaluated, set up the pointers for the LDAPMod
2076 */
2077 memcpy(&(usermod_ctx->mod_s[mod_no].mod_type), &mod->attr, sizeof(usermod_ctx->mod_s[mod_no].mod_type));
2078 usermod_ctx->mod_s[mod_no].mod_bvalues = value_refs;
2079 usermod_ctx->mod_p[mod_no] = &usermod_ctx->mod_s[mod_no];
2080
2081 usermod_ctx->expanded_mods++;
2082 usermod_ctx->mod_p[usermod_ctx->expanded_mods] = NULL;
2083
2084next:
2085 usermod_ctx->current_mod++;
2086 if (usermod_ctx->current_mod < usermod_ctx->num_mods) {
2088 if (unlang_tmpl_push(usermod_ctx, &usermod_ctx->expanded, request,
2089 usermod_ctx->call_env->mod[usermod_ctx->current_mod]->tmpl, NULL) < 0) RETURN_MODULE_FAIL;
2091 }
2092
2093 modify = usermod_ctx->mod_p;
2094
2096 UNLANG_SUB_FRAME, usermod_ctx) < 0) RETURN_MODULE_FAIL;
2097
2098 return fr_ldap_trunk_modify(usermod_ctx, &usermod_ctx->query, request, usermod_ctx->ttrunk,
2099 usermod_ctx->dn, modify, NULL, NULL);
2100}
2101
2102/** Take the retrieved user DN and launch the async tmpl expansion of mod_values.
2103 *
2104 */
2106 request_t *request, void *uctx)
2107{
2108 ldap_user_modify_ctx_t *usermod_ctx = talloc_get_type_abort(uctx, ldap_user_modify_ctx_t);
2109
2110 /*
2111 * If an LDAP search was used to find the user DN
2112 * usermod_ctx->dn will be NULL.
2113 */
2114 if (!usermod_ctx->dn) usermod_ctx->dn = rlm_find_user_dn_cached(request);
2115
2116 if (!usermod_ctx->dn) {
2117 fail:
2118 talloc_free(usermod_ctx);
2120 }
2121
2122 /*
2123 * Allocate arrays to hold mods. mod_p is one element longer to hold a terminating NULL entry
2124 */
2125 MEM(usermod_ctx->mod_p = talloc_zero_array(usermod_ctx, LDAPMod *, usermod_ctx->num_mods + 1));
2126 MEM(usermod_ctx->mod_s = talloc_array(usermod_ctx, LDAPMod, usermod_ctx->num_mods));
2127 fr_value_box_list_init(&usermod_ctx->expanded);
2128
2129 if (unlang_function_repeat_set(request, user_modify_mod_build_resume) < 0) goto fail;
2130 if (unlang_tmpl_push(usermod_ctx, &usermod_ctx->expanded, request,
2131 usermod_ctx->call_env->mod[0]->tmpl, NULL) < 0) goto fail;
2132
2134}
2135
2136/** Modify user's object in LDAP
2137 *
2138 * Process a modification map to update a user object in the LDAP directory.
2139 *
2140 * The module method called in "accouting" and "send" sections.
2141 */
2142static unlang_action_t CC_HINT(nonnull) mod_modify(rlm_rcode_t *p_result, module_ctx_t const *mctx, request_t *request)
2143{
2145 ldap_usermod_call_env_t *call_env = talloc_get_type_abort(mctx->env_data, ldap_usermod_call_env_t);
2146
2148 fr_ldap_thread_t *thread = talloc_get_type_abort(module_thread(inst->mi)->data, fr_ldap_thread_t);
2149 ldap_user_modify_ctx_t *usermod_ctx = NULL;
2150
2151 size_t num_mods = talloc_array_length(call_env->mod);
2152
2153 if (num_mods == 0) RETURN_MODULE_NOOP;
2154
2155 /*
2156 * Include a talloc pool allowing for one value per modification
2157 */
2159 2 * num_mods + 2,
2160 (sizeof(struct berval) + (sizeof(struct berval *) * 2) +
2161 (sizeof(LDAPMod) + sizeof(LDAPMod *))) * num_mods));
2162 *usermod_ctx = (ldap_user_modify_ctx_t) {
2163 .inst = inst,
2164 .call_env = call_env,
2165 .num_mods = num_mods
2166 };
2167
2168 usermod_ctx->ttrunk = fr_thread_ldap_trunk_get(thread, inst->handle_config.server,
2169 inst->handle_config.admin_identity,
2170 inst->handle_config.admin_password,
2171 request, &inst->handle_config);
2172 if (!usermod_ctx->ttrunk) {
2173 REDEBUG("Unable to get LDAP trunk for update");
2174 talloc_free(usermod_ctx);
2176 }
2177
2178 usermod_ctx->dn = rlm_find_user_dn_cached(request);
2179
2180 if (unlang_function_push(request, usermod_ctx->dn ? NULL : user_modify_start, user_modify_resume,
2181 NULL, 0, UNLANG_SUB_FRAME, usermod_ctx) < 0) goto error;
2182
2184
2185error:
2186 TALLOC_FREE(usermod_ctx);
2187 RETURN_MODULE_RCODE(rcode);
2188}
2189
2190/** Detach from the LDAP server and cleanup internal state.
2191 *
2192 */
2193static int mod_detach(module_detach_ctx_t const *mctx)
2194{
2195 rlm_ldap_t *inst = talloc_get_type_abort(mctx->mi->data, rlm_ldap_t);
2196
2197 if (inst->user.obj_sort_ctrl) ldap_control_free(inst->user.obj_sort_ctrl);
2198 if (inst->profile.obj_sort_ctrl) ldap_control_free(inst->profile.obj_sort_ctrl);
2199
2200 return 0;
2201}
2202
2203static int ldap_update_section_parse(TALLOC_CTX *ctx, call_env_parsed_head_t *out, tmpl_rules_t const *t_rules,
2204 CONF_ITEM *ci,
2205 UNUSED call_env_ctx_t const *cec, call_env_parser_t const *rule)
2206{
2207 map_list_t *maps;
2208 CONF_SECTION *update = cf_item_to_section(ci);
2209 ldap_update_rules_t const *ur = rule->uctx;
2210
2211 bool expect_password = false;
2212
2213 /*
2214 * Build the attribute map
2215 */
2216 {
2217 map_t const *map = NULL;
2218 tmpl_attr_t const *ar;
2219 call_env_parsed_t *parsed;
2220
2221 MEM(parsed = call_env_parsed_add(ctx, out,
2223 .name = "update",
2224 .flags = CALL_ENV_FLAG_PARSE_ONLY,
2225 .pair = {
2226 .parsed = {
2227 .offset = ur->map_offset,
2229 }
2230 }
2231 }));
2232
2233 MEM(maps = talloc(parsed, map_list_t));
2234 map_list_init(maps);
2235
2236 if (update && (map_afrom_cs(maps, maps, update, t_rules, t_rules, fr_ldap_map_verify,
2237 NULL, LDAP_MAX_ATTRMAP)) < 0) {
2238 call_env_parsed_free(out, parsed);
2239 return -1;
2240 }
2241 /*
2242 * Check map to see if a password is being retrieved.
2243 * fr_ldap_map_verify ensures that all maps have attributes on the LHS.
2244 * All passwords have a common parent attribute of attr_password
2245 */
2246 while ((map = map_list_next(maps, map))) {
2247 ar = tmpl_attr_tail(map->lhs);
2248 if (ar->da->parent == attr_password) {
2249 expect_password = true;
2250 break;
2251 }
2252 }
2253 call_env_parsed_set_data(parsed, maps);
2254 }
2255
2256 /*
2257 * Write out whether we expect a password to be returned from the ldap data
2258 */
2259 if (ur->expect_password_offset >= 0) {
2260 call_env_parsed_t *parsed;
2261 fr_value_box_t *vb;
2262
2263 MEM(parsed = call_env_parsed_add(ctx, out,
2265 .name = "expect_password",
2266 .flags = CALL_ENV_FLAG_PARSE_ONLY,
2267 .pair = {
2268 .parsed = {
2269 .offset = ur->expect_password_offset,
2271 }
2272 }
2273 }));
2274 MEM(vb = fr_value_box_alloc(parsed, FR_TYPE_BOOL, NULL));
2275 vb->vb_bool = expect_password;
2276 call_env_parsed_set_value(parsed, vb);
2277 }
2278
2279 return 0;
2280}
2281
2282static int ldap_mod_section_parse(TALLOC_CTX *ctx, call_env_parsed_head_t *out, tmpl_rules_t const *t_rules,
2283 CONF_ITEM *ci, call_env_ctx_t const *cec, UNUSED call_env_parser_t const *rule)
2284{
2285 CONF_SECTION const *subcs = NULL;
2286 CONF_PAIR const *to_parse = NULL;
2287 tmpl_t *parsed_tmpl;
2288 call_env_parsed_t *parsed_env;
2289 char *section2, *p;
2290 ssize_t count, slen, multi_index = 0;
2291 ldap_mod_tmpl_t *mod;
2292
2294
2295 section2 = talloc_strdup(NULL, section_name_str(cec->asked->name2));
2296 p = section2;
2297 while (*p != '\0') {
2298 *(p) = tolower((uint8_t)*p);
2299 p++;
2300 }
2301
2302 if (!ci) {
2303 not_found:
2304 cf_log_warn(ci, "No section found for \"%s.%s\" in module \"%s\", this call will have no effect.",
2305 section_name_str(cec->asked->name1), section2, cec->mi->name);
2306 free:
2307 talloc_free(section2);
2308 return 0;
2309 }
2310
2311 subcs = cf_section_find(cf_item_to_section(ci), section2, CF_IDENT_ANY);
2312 if (!subcs) goto not_found;
2313
2314 subcs = cf_section_find(subcs, "update", CF_IDENT_ANY);
2315 if (!subcs) {
2316 cf_log_warn(ci, "No update found inside \"%s -> %s\" in module \"%s\"",
2317 section_name_str(cec->asked->name1), section2, cec->mi->name);
2318 goto free;
2319 }
2320
2322 if (count == 0) {
2323 cf_log_warn(ci, "No modifications found for \"%s.%s\" in module \"%s\"",
2324 section_name_str(cec->asked->name1), section2, cec->mi->name);
2325 goto free;
2326 }
2327 talloc_free(section2);
2328
2329 while ((to_parse = cf_pair_next(subcs, to_parse))) {
2330 switch (cf_pair_operator(to_parse)) {
2331 case T_OP_SET:
2332 case T_OP_ADD_EQ:
2333 case T_OP_SUB_EQ:
2334 case T_OP_CMP_FALSE:
2335 case T_OP_INCRM:
2336 break;
2337
2338 default:
2339 cf_log_perr(to_parse, "Invalid operator for LDAP modification");
2340 return -1;
2341 }
2342
2343 MEM(parsed_env = call_env_parsed_add(ctx, out,
2348 }));
2349
2350 slen = tmpl_afrom_substr(parsed_env, &parsed_tmpl,
2351 &FR_SBUFF_IN(cf_pair_value(to_parse), talloc_array_length(cf_pair_value(to_parse)) - 1),
2353 t_rules);
2354
2355 if (slen <= 0) {
2356 cf_canonicalize_error(to_parse, slen, "Failed parsing LDAP modification \"%s\"", cf_pair_value(to_parse));
2357 error:
2358 call_env_parsed_free(out, parsed_env);
2359 return -1;
2360 }
2361 if (tmpl_needs_resolving(parsed_tmpl) &&
2362 (tmpl_resolve(parsed_tmpl, &(tmpl_res_rules_t){ .dict_def = t_rules->attr.dict_def }) <0)) {
2363 cf_log_perr(to_parse, "Failed resolving LDAP modification \"%s\"", cf_pair_value(to_parse));
2364 goto error;
2365 }
2366
2367 MEM(mod = talloc(parsed_env, ldap_mod_tmpl_t));
2368 mod->attr = cf_pair_attr(to_parse);
2369 mod->tmpl = parsed_tmpl;
2370 mod->op = cf_pair_operator(to_parse);
2371
2372 call_env_parsed_set_multi_index(parsed_env, count, multi_index++);
2373 call_env_parsed_set_data(parsed_env, mod);
2374 }
2375
2376 return 0;
2377}
2378
2379static int ldap_group_filter_parse(TALLOC_CTX *ctx, void *out, tmpl_rules_t const *t_rules, UNUSED CONF_ITEM *ci,
2380 call_env_ctx_t const *cec, UNUSED call_env_parser_t const *rule)
2381{
2383 char const *filters[] = { inst->group.obj_filter, inst->group.obj_membership_filter };
2384 tmpl_t *parsed;
2385
2386 if (fr_ldap_filter_to_tmpl(ctx, t_rules, filters, NUM_ELEMENTS(filters), &parsed) < 0) return -1;
2387
2388 *(void **)out = parsed;
2389 return 0;
2390}
2391
2392/** Clean up thread specific data structure
2393 *
2394 */
2396{
2397 fr_ldap_thread_t *t = talloc_get_type_abort(mctx->thread, fr_ldap_thread_t);
2398 void **trunks_to_free;
2399 int i;
2400
2401 if (fr_rb_flatten_inorder(NULL, &trunks_to_free, t->trunks) < 0) return -1;
2402
2403 for (i = talloc_array_length(trunks_to_free) - 1; i >= 0; i--) talloc_free(trunks_to_free[i]);
2404 talloc_free(trunks_to_free);
2405 talloc_free(t->trunks);
2406
2407 return 0;
2408}
2409
2410/** Initialise thread specific data structure
2411 *
2412 */
2414{
2415 rlm_ldap_t *inst = talloc_get_type_abort(mctx->mi->data, rlm_ldap_t);
2416 fr_ldap_thread_t *t = talloc_get_type_abort(mctx->thread, fr_ldap_thread_t);
2417 fr_ldap_thread_trunk_t *ttrunk;
2418
2419 /*
2420 * Initialise tree for connection trunks used by this thread
2421 */
2423
2424 t->config = &inst->handle_config;
2425 t->trunk_conf = &inst->trunk_conf;
2426 t->bind_trunk_conf = &inst->bind_trunk_conf;
2427 t->el = mctx->el;
2428
2429 /*
2430 * Launch trunk for module default connection
2431 */
2432 ttrunk = fr_thread_ldap_trunk_get(t, inst->handle_config.server, inst->handle_config.admin_identity,
2433 inst->handle_config.admin_password, NULL, &inst->handle_config);
2434 if (!ttrunk) {
2435 ERROR("Unable to launch LDAP trunk");
2436 return -1;
2437 }
2438
2439 /*
2440 * Set up a per-thread LDAP trunk to use for bind auths
2441 */
2443
2445
2446 return 0;
2447}
2448
2449/** Instantiate the module
2450 *
2451 * Creates a new instance of the module reading parameters from a configuration section.
2452 *
2453 * @param [in] mctx configuration data.
2454 * @return
2455 * - 0 on success.
2456 * - < 0 on failure.
2457 */
2458static int mod_instantiate(module_inst_ctx_t const *mctx)
2459{
2460 size_t i;
2461
2462 CONF_SECTION *options;
2463 rlm_ldap_boot_t const *boot = talloc_get_type_abort(mctx->mi->boot, rlm_ldap_boot_t);
2464 rlm_ldap_t *inst = talloc_get_type_abort(mctx->mi->data, rlm_ldap_t);
2465 CONF_SECTION *conf = mctx->mi->conf;
2466
2467 inst->mi = mctx->mi; /* Cached for IO callbacks */
2468 inst->group.da = boot->group_da;
2469 inst->group.cache_da = boot->cache_da;
2470
2471 inst->handle_config.name = talloc_typed_asprintf(inst, "rlm_ldap (%s)", mctx->mi->name);
2472
2473 /*
2474 * Trunks used for bind auth can only have one request in flight per connection.
2475 */
2476 inst->bind_trunk_conf.target_req_per_conn = 1;
2477 inst->bind_trunk_conf.max_req_per_conn = 1;
2478
2479 /*
2480 * Set sizes for trunk request pool.
2481 */
2482 inst->bind_trunk_conf.req_pool_headers = 2;
2483 inst->bind_trunk_conf.req_pool_size = sizeof(fr_ldap_bind_auth_ctx_t) + sizeof(fr_ldap_sasl_ctx_t);
2484
2485 options = cf_section_find(conf, "options", NULL);
2486 if (!options || !cf_pair_find(options, "chase_referrals")) {
2487 inst->handle_config.chase_referrals_unset = true; /* use OpenLDAP defaults */
2488 }
2489
2490 /*
2491 * Sanity checks for cacheable groups code.
2492 */
2493 if (inst->group.cacheable_name && inst->group.obj_membership_filter) {
2494 if (!inst->group.obj_name_attr) {
2495 cf_log_err(conf, "Configuration item 'group.name_attribute' must be set if cacheable "
2496 "group names are enabled");
2497
2498 goto error;
2499 }
2500 }
2501
2502 /*
2503 * If we have a *pair* as opposed to a *section*
2504 * then the module is referencing another ldap module's
2505 * connection pool.
2506 */
2507 if (!cf_pair_find(conf, "pool")) {
2508 if (!inst->handle_config.server_str) {
2509 cf_log_err(conf, "Configuration item 'server' must have a value");
2510 goto error;
2511 }
2512 }
2513
2514#ifndef WITH_SASL
2515 if (inst->handle_config.admin_sasl.mech) {
2516 cf_log_err(conf, "Configuration item 'sasl.mech' not supported. "
2517 "Linked libldap does not provide ldap_sasl_interactive_bind function");
2518 goto error;
2519 }
2520#endif
2521
2522 /*
2523 * Initialise server with zero length string to
2524 * make code below simpler.
2525 */
2526 inst->handle_config.server = talloc_strdup(inst, "");
2527
2528 /*
2529 * Now iterate over all the 'server' config items
2530 */
2531 for (i = 0; i < talloc_array_length(inst->handle_config.server_str); i++) {
2532 char const *value = inst->handle_config.server_str[i];
2533 size_t j;
2534
2535 /*
2536 * Explicitly prevent multiple server definitions
2537 * being used in the same string.
2538 */
2539 for (j = 0; j < talloc_array_length(value) - 1; j++) {
2540 switch (value[j]) {
2541 case ' ':
2542 case ',':
2543 case ';':
2544 cf_log_err(conf, "Invalid character '%c' found in 'server' configuration item",
2545 value[j]);
2546 goto error;
2547
2548 default:
2549 continue;
2550 }
2551 }
2552
2553 /*
2554 * Split original server value out into URI, server and port
2555 * so whatever initialization function we use later will have
2556 * the server information in the format it needs.
2557 */
2558 if (ldap_is_ldap_url(value)) {
2559 if (fr_ldap_server_url_check(&inst->handle_config, value, conf) < 0) return -1;
2560 } else
2561 /*
2562 * If it's not an URL, then just treat server as a hostname.
2563 */
2564 {
2565 if (fr_ldap_server_config_check(&inst->handle_config, value, conf) < 0) return -1;
2566 }
2567 }
2568
2569 /*
2570 * inst->handle_config.server be unset if connection pool sharing is used.
2571 */
2572 if (inst->handle_config.server) {
2573 inst->handle_config.server[talloc_array_length(inst->handle_config.server) - 2] = '\0';
2574 DEBUG4("rlm_ldap (%s) - LDAP server string: %s", mctx->mi->name, inst->handle_config.server);
2575 }
2576
2577 /*
2578 * Workaround for servers which support LDAPS but not START TLS
2579 */
2580 if (inst->handle_config.port == LDAPS_PORT || inst->handle_config.tls_mode) {
2581 inst->handle_config.tls_mode = LDAP_OPT_X_TLS_HARD;
2582 } else {
2583 inst->handle_config.tls_mode = 0;
2584 }
2585
2586 /*
2587 * Convert dereference strings to enumerated constants
2588 */
2589 if (inst->handle_config.dereference_str) {
2590 inst->handle_config.dereference = fr_table_value_by_str(fr_ldap_dereference,
2591 inst->handle_config.dereference_str, -1);
2592 if (inst->handle_config.dereference < 0) {
2593 cf_log_err(conf, "Invalid 'dereference' value \"%s\", expected 'never', 'searching', "
2594 "'finding' or 'always'", inst->handle_config.dereference_str);
2595 goto error;
2596 }
2597 }
2598
2599 /*
2600 * Build the server side sort control for user / profile objects
2601 */
2602#define SSS_CONTROL_BUILD(_obj) if (inst->_obj.obj_sort_by) { \
2603 LDAPSortKey **keys; \
2604 int ret; \
2605 ret = ldap_create_sort_keylist(&keys, UNCONST(char *, inst->_obj.obj_sort_by)); \
2606 if (ret != LDAP_SUCCESS) { \
2607 cf_log_err(conf, "Invalid " STRINGIFY(_obj) ".sort_by value \"%s\": %s", \
2608 inst->_obj.obj_sort_by, ldap_err2string(ret)); \
2609 goto error; \
2610 } \
2611 /* \
2612 * Always set the control as critical, if it's not needed \
2613 * the user can comment it out... \
2614 */ \
2615 ret = ldap_create_sort_control(ldap_global_handle, keys, 1, &inst->_obj.obj_sort_ctrl); \
2616 ldap_free_sort_keylist(keys); \
2617 if (ret != LDAP_SUCCESS) { \
2618 ERROR("Failed creating server sort control: %s", ldap_err2string(ret)); \
2619 goto error; \
2620 } \
2621 }
2622
2623 SSS_CONTROL_BUILD(user)
2624 SSS_CONTROL_BUILD(profile)
2625
2626 if (inst->handle_config.tls_require_cert_str) {
2627 /*
2628 * Convert cert strictness to enumerated constants
2629 */
2630 inst->handle_config.tls_require_cert = fr_table_value_by_str(fr_ldap_tls_require_cert,
2631 inst->handle_config.tls_require_cert_str, -1);
2632 if (inst->handle_config.tls_require_cert < 0) {
2633 cf_log_err(conf, "Invalid 'tls.require_cert' value \"%s\", expected 'never', "
2634 "'demand', 'allow', 'try' or 'hard'", inst->handle_config.tls_require_cert_str);
2635 goto error;
2636 }
2637 }
2638
2639 if (inst->handle_config.tls_min_version_str) {
2640 if (strcmp(inst->handle_config.tls_min_version_str, "1.3") == 0) {
2641 inst->handle_config.tls_min_version = LDAP_OPT_X_TLS_PROTOCOL_TLS1_3;
2642
2643 } else if (strcmp(inst->handle_config.tls_min_version_str, "1.2") == 0) {
2644 inst->handle_config.tls_min_version = LDAP_OPT_X_TLS_PROTOCOL_TLS1_2;
2645
2646 } else if (strcmp(inst->handle_config.tls_min_version_str, "1.1") == 0) {
2647 inst->handle_config.tls_min_version = LDAP_OPT_X_TLS_PROTOCOL_TLS1_1;
2648
2649 } else if (strcmp(inst->handle_config.tls_min_version_str, "1.0") == 0) {
2650 inst->handle_config.tls_min_version = LDAP_OPT_X_TLS_PROTOCOL_TLS1_0;
2651
2652 } else {
2653 cf_log_err(conf, "Invalid 'tls.tls_min_version' value \"%s\"", inst->handle_config.tls_min_version_str);
2654 goto error;
2655 }
2656 }
2657
2658 return 0;
2659
2660error:
2661 return -1;
2662}
2663
2664/** Bootstrap the module
2665 *
2666 * Define attributes.
2667 *
2668 * @param[in] mctx configuration data.
2669 * @return
2670 * - 0 on success.
2671 * - < 0 on failure.
2672 */
2673static int mod_bootstrap(module_inst_ctx_t const *mctx)
2674{
2675 rlm_ldap_boot_t *boot = talloc_get_type_abort(mctx->mi->boot, rlm_ldap_boot_t);
2676 rlm_ldap_t const *inst = talloc_get_type_abort(mctx->mi->data, rlm_ldap_t);
2677 CONF_SECTION *conf = mctx->mi->conf;
2678 char buffer[256];
2679 char const *group_attribute;
2680 xlat_t *xlat;
2681
2682 if (inst->group.attribute) {
2683 group_attribute = inst->group.attribute;
2684 } else if (cf_section_name2(conf)) {
2685 snprintf(buffer, sizeof(buffer), "%s-LDAP-Group", mctx->mi->name);
2686 group_attribute = buffer;
2687 } else {
2688 group_attribute = "LDAP-Group";
2689 }
2690
2691 boot->group_da = fr_dict_attr_by_name(NULL, fr_dict_root(dict_freeradius), group_attribute);
2692
2693 /*
2694 * If the group attribute was not in the dictionary, create it
2695 */
2696 if (!boot->group_da) {
2698 group_attribute, FR_TYPE_STRING, NULL) < 0) {
2699 PERROR("Error creating group attribute");
2700 return -1;
2701
2702 }
2703 boot->group_da = fr_dict_attr_by_name(NULL, fr_dict_root(dict_freeradius), group_attribute);
2704 }
2705
2706 /*
2707 * Setup the cache attribute
2708 */
2709
2710 if (inst->group.cache_attribute) {
2711 boot->cache_da = fr_dict_attr_by_name(NULL, fr_dict_root(dict_freeradius), inst->group.cache_attribute);
2712 if (!boot->cache_da) {
2714 inst->group.cache_attribute, FR_TYPE_STRING, NULL) < 0) {
2715 PERROR("Error creating cache attribute");
2716 return -1;
2717 }
2718 boot->cache_da = fr_dict_attr_by_name(NULL, fr_dict_root(dict_freeradius), inst->group.cache_attribute);
2719 }
2720 } else {
2721 boot->cache_da = boot->group_da; /* Default to the group_da */
2722 }
2723
2724 xlat = module_rlm_xlat_register(mctx->mi->boot, mctx, NULL, ldap_xlat, FR_TYPE_STRING);
2726
2727 if (unlikely(!(xlat = module_rlm_xlat_register(mctx->mi->boot, mctx, "group", ldap_group_xlat,
2728 FR_TYPE_BOOL)))) return -1;
2731
2732 if (unlikely(!(xlat = module_rlm_xlat_register(mctx->mi->boot, mctx, "profile", ldap_profile_xlat,
2733 FR_TYPE_BOOL)))) return -1;
2736
2738
2739 return 0;
2740}
2741
2742static int mod_load(void)
2743{
2744 xlat_t *xlat;
2745
2746 if (unlikely(!(xlat = xlat_func_register(NULL, "ldap.uri.escape", ldap_uri_escape_xlat, FR_TYPE_STRING)))) return -1;
2749 xlat_func_safe_for_set(xlat, LDAP_URI_SAFE_FOR); /* Used for all LDAP escaping */
2750
2751 if (unlikely(!(xlat = xlat_func_register(NULL, "ldap.uri.safe", xlat_transparent, FR_TYPE_STRING)))) return -1;
2755
2756 if (unlikely(!(xlat = xlat_func_register(NULL, "ldap.uri.unescape", ldap_uri_unescape_xlat, FR_TYPE_STRING)))) return -1;
2759
2760 return 0;
2761}
2762
2763static void mod_unload(void)
2764{
2765 xlat_func_unregister("ldap.uri.escape");
2766 xlat_func_unregister("ldap.uri.safe");
2767 xlat_func_unregister("ldap.uri.unescape");
2768}
2770/* globally exported name */
2771extern module_rlm_t rlm_ldap;
2773 .common = {
2774 .magic = MODULE_MAGIC_INIT,
2775 .name = "ldap",
2776 .flags = 0,
2777 .boot_size = sizeof(rlm_ldap_boot_t),
2778 .boot_type = "rlm_ldap_boot_t",
2779 .inst_size = sizeof(rlm_ldap_t),
2780 .config = module_config,
2781 .onload = mod_load,
2782 .unload = mod_unload,
2783 .bootstrap = mod_bootstrap,
2784 .instantiate = mod_instantiate,
2785 .detach = mod_detach,
2786 .thread_inst_size = sizeof(fr_ldap_thread_t),
2787 .thread_inst_type = "fr_ldap_thread_t",
2790 },
2791 .method_group = {
2792 .bindings = (module_method_binding_t[]){
2793 /*
2794 * Hack to support old configurations
2795 */
2796 { .section = SECTION_NAME("accounting", CF_IDENT_ANY), .method = mod_modify, .method_env = &accounting_usermod_method_env },
2797 { .section = SECTION_NAME("authenticate", CF_IDENT_ANY), .method = mod_authenticate, .method_env = &authenticate_method_env },
2798 { .section = SECTION_NAME("authorize", CF_IDENT_ANY), .method = mod_authorize, .method_env = &authorize_method_env },
2799
2800 { .section = SECTION_NAME("recv", CF_IDENT_ANY), .method = mod_authorize, .method_env = &authorize_method_env },
2801 { .section = SECTION_NAME("send", CF_IDENT_ANY), .method = mod_modify, .method_env = &send_usermod_method_env },
2803 }
2804 }
2805};
unlang_action_t
Returned by unlang_op_t calls, determine the next action of the interpreter.
Definition action.h:35
@ UNLANG_ACTION_PUSHED_CHILD
unlang_t pushed a new child onto the stack, execute it instead of continuing.
Definition action.h:39
@ UNLANG_ACTION_FAIL
Encountered an unexpected error.
Definition action.h:36
@ UNLANG_ACTION_CALCULATE_RESULT
Calculate a new section rlm_rcode_t value.
Definition action.h:37
static int const char char buffer[256]
Definition acutest.h:576
log_entry msg
Definition acutest.h:794
#define USES_APPLE_DEPRECATED_API
Definition build.h:472
#define RCSID(id)
Definition build.h:485
#define L(_str)
Helper for initialising arrays of string literals.
Definition build.h:209
#define FALL_THROUGH
clang 10 doesn't recognised the FALL-THROUGH comment anymore
Definition build.h:324
#define unlikely(_x)
Definition build.h:383
#define UNUSED
Definition build.h:317
#define NUM_ELEMENTS(_t)
Definition build.h:339
void call_env_parsed_free(call_env_parsed_head_t *parsed, call_env_parsed_t *ptr)
Remove a call_env_parsed_t from the list of parsed call envs.
Definition call_env.c:733
call_env_parsed_t * call_env_parsed_add(TALLOC_CTX *ctx, call_env_parsed_head_t *head, call_env_parser_t const *rule)
Allocate a new call_env_parsed_t structure and add it to the list of parsed call envs.
Definition call_env.c:646
void call_env_parsed_set_multi_index(call_env_parsed_t *parsed, size_t count, size_t index)
Assign a count and index to a call_env_parsed_t.
Definition call_env.c:718
void call_env_parsed_set_data(call_env_parsed_t *parsed, void const *data)
Assign data to a call_env_parsed_t.
Definition call_env.c:703
void call_env_parsed_set_value(call_env_parsed_t *parsed, fr_value_box_t const *vb)
Assign a value box to a call_env_parsed_t.
Definition call_env.c:689
#define CALL_ENV_TERMINATOR
Definition call_env.h:236
call_env_ctx_type_t type
Type of callenv ctx.
Definition call_env.h:227
@ CALL_ENV_CTX_TYPE_MODULE
The callenv is registered to a module method.
Definition call_env.h:222
#define FR_CALL_ENV_PARSE_OFFSET(_name, _cast_type, _flags, _struct, _field, _parse_field)
Specify a call_env_parser_t which writes out runtime results and the result of the parsing phase to t...
Definition call_env.h:365
#define FR_CALL_ENV_METHOD_OUT(_inst)
Helper macro for populating the size/type fields of a call_env_method_t from the output structure typ...
Definition call_env.h:240
call_env_parser_t const * env
Parsing rules for call method env.
Definition call_env.h:247
section_name_t const * asked
The actual name1/name2 that resolved to a module_method_binding_t.
Definition call_env.h:232
void const * uctx
User context for callback functions.
Definition call_env.h:218
#define FR_CALL_ENV_SUBSECTION(_name, _name2, _flags, _subcs)
Specify a call_env_parser_t which defines a nested subsection.
Definition call_env.h:402
@ CALL_ENV_FLAG_CONCAT
If the tmpl produced multiple boxes they should be concatenated.
Definition call_env.h:76
@ CALL_ENV_FLAG_ATTRIBUTE
Tmpl MUST contain an attribute reference.
Definition call_env.h:86
@ CALL_ENV_FLAG_PARSE_ONLY
The result of parsing will not be evaluated at runtime.
Definition call_env.h:85
@ CALL_ENV_FLAG_NONE
Definition call_env.h:74
@ CALL_ENV_FLAG_MULTI
Multiple instances of the conf pairs are allowed.
Definition call_env.h:78
@ CALL_ENV_FLAG_REQUIRED
Associated conf pair or section is required.
Definition call_env.h:75
@ CALL_ENV_FLAG_PARSE_MISSING
If this subsection is missing, still parse it.
Definition call_env.h:88
@ CALL_ENV_FLAG_BARE_WORD_ATTRIBUTE
bare words are treated as an attribute, but strings may be xlats.
Definition call_env.h:92
@ CALL_ENV_FLAG_NULLABLE
Tmpl expansions are allowed to produce no output.
Definition call_env.h:80
@ CALL_ENV_PARSE_TYPE_VALUE_BOX
Output of the parsing phase is a single value box (static data).
Definition call_env.h:61
@ CALL_ENV_PARSE_TYPE_VOID
Output of the parsing phase is undefined (a custom structure).
Definition call_env.h:62
module_instance_t const * mi
Module instance that the callenv is registered to.
Definition call_env.h:229
#define FR_CALL_ENV_SUBSECTION_FUNC(_name, _name2, _flags, _func)
Specify a call_env_parser_t which parses a subsection using a callback function.
Definition call_env.h:412
#define FR_CALL_ENV_OFFSET(_name, _cast_type, _flags, _struct, _field)
Specify a call_env_parser_t which writes out runtime results to the specified field.
Definition call_env.h:340
#define FR_CALL_ENV_PARSE_ONLY_OFFSET(_name, _cast_type, _flags, _struct, _parse_field)
Specify a call_env_parser_t which writes out the result of the parsing phase to the field specified.
Definition call_env.h:389
Per method call config.
Definition call_env.h:180
int cf_table_parse_int(UNUSED TALLOC_CTX *ctx, void *out, UNUSED void *parent, CONF_ITEM *ci, conf_parser_t const *rule)
Generic function for parsing conf pair values as int.
Definition cf_parse.c:1592
#define CONF_PARSER_TERMINATOR
Definition cf_parse.h:658
cf_parse_t func
Override default parsing behaviour for the specified type with a custom parsing function.
Definition cf_parse.h:612
#define FR_CONF_OFFSET(_name, _struct, _field)
conf_parser_t which parses a single CONF_PAIR, writing the result to a field in a struct
Definition cf_parse.h:284
#define FR_CONF_POINTER(_name, _type, _flags, _res_p)
conf_parser_t which parses a single CONF_PAIR producing a single global result
Definition cf_parse.h:339
#define FR_CONF_OFFSET_IS_SET(_name, _type, _flags, _struct, _field)
conf_parser_t which parses a single CONF_PAIR, writing the result to a field in a struct,...
Definition cf_parse.h:298
#define FR_CONF_OFFSET_FLAGS(_name, _flags, _struct, _field)
conf_parser_t which parses a single CONF_PAIR, writing the result to a field in a struct
Definition cf_parse.h:272
#define FR_CONF_OFFSET_SUBSECTION(_name, _flags, _struct, _field, _subcs)
conf_parser_t which populates a sub-struct using a CONF_SECTION
Definition cf_parse.h:313
@ CONF_FLAG_MULTI
CONF_PAIR can have multiple copies.
Definition cf_parse.h:448
@ CONF_FLAG_XLAT
string will be dynamically expanded.
Definition cf_parse.h:445
@ CONF_FLAG_SUBSECTION
Instead of putting the information into a configuration structure, the configuration file routines MA...
Definition cf_parse.h:428
Defines a CONF_PAIR to C data type mapping.
Definition cf_parse.h:595
Common header for all CONF_* types.
Definition cf_priv.h:49
Configuration AVP similar to a fr_pair_t.
Definition cf_priv.h:70
A section grouping multiple CONF_PAIR.
Definition cf_priv.h:101
unsigned int cf_pair_count_descendents(CONF_SECTION const *cs)
Count the number of conf pairs beneath a section.
Definition cf_util.c:1504
char const * cf_section_name2(CONF_SECTION const *cs)
Return the second identifier of a CONF_SECTION.
Definition cf_util.c:1184
CONF_SECTION * cf_section_find(CONF_SECTION const *cs, char const *name1, char const *name2)
Find a CONF_SECTION with name1 and optionally name2.
Definition cf_util.c:1027
CONF_SECTION * cf_item_to_section(CONF_ITEM const *ci)
Cast a CONF_ITEM to a CONF_SECTION.
Definition cf_util.c:683
CONF_PAIR * cf_pair_find(CONF_SECTION const *cs, char const *attr)
Search for a CONF_PAIR with a specific name.
Definition cf_util.c:1438
fr_token_t cf_pair_operator(CONF_PAIR const *pair)
Return the operator of a pair.
Definition cf_util.c:1607
fr_token_t cf_pair_value_quote(CONF_PAIR const *pair)
Return the value (rhs) quoting of a pair.
Definition cf_util.c:1637
CONF_PAIR * cf_pair_next(CONF_SECTION const *cs, CONF_PAIR const *curr)
Return the next child that's a CONF_PAIR.
Definition cf_util.c:1412
char const * cf_pair_value(CONF_PAIR const *pair)
Return the value of a CONF_PAIR.
Definition cf_util.c:1593
char const * cf_pair_attr(CONF_PAIR const *pair)
Return the attr of a CONF_PAIR.
Definition cf_util.c:1577
#define cf_log_err(_cf, _fmt,...)
Definition cf_util.h:289
#define cf_canonicalize_error(_ci, _slen, _msg, _str)
Definition cf_util.h:367
#define cf_log_perr(_cf, _fmt,...)
Definition cf_util.h:296
#define cf_log_warn(_cf, _fmt,...)
Definition cf_util.h:290
#define CF_IDENT_ANY
Definition cf_util.h:78
static int fr_dcursor_append(fr_dcursor_t *cursor, void *v)
Insert a single item at the end of the list.
Definition dcursor.h:408
#define MEM(x)
Definition debug.h:36
#define ERROR(fmt,...)
Definition dhcpclient.c:41
int fr_dict_attr_add_name_only(fr_dict_t *dict, fr_dict_attr_t const *parent, char const *name, fr_type_t type, fr_dict_attr_flags_t const *flags))
Add an attribute to the dictionary.
Definition dict_util.c:1741
fr_dict_t * fr_dict_unconst(fr_dict_t const *dict)
Coerce to non-const.
Definition dict_util.c:4629
fr_dict_attr_t const * fr_dict_attr_by_name(fr_dict_attr_err_t *err, fr_dict_attr_t const *parent, char const *attr))
Locate a fr_dict_attr_t by its name.
Definition dict_util.c:3266
fr_dict_attr_t const * fr_dict_root(fr_dict_t const *dict)
Return the root attribute of a dictionary.
Definition dict_util.c:2403
fr_dict_attr_t const ** out
Where to write a pointer to the resolved fr_dict_attr_t.
Definition dict.h:273
fr_dict_t const ** out
Where to write a pointer to the loaded/resolved fr_dict_t.
Definition dict.h:286
static fr_slen_t in
Definition dict.h:840
Specifies an attribute which must be present for the module to function.
Definition dict.h:272
Specifies a dictionary which must be loaded/loadable for the module to function.
Definition dict.h:285
Test enumeration values.
Definition dict_test.h:92
#define MODULE_MAGIC_INIT
Stop people using different module/library/server versions together.
Definition dl_module.h:63
#define unlang_function_repeat_set(_request, _repeat)
Set a new repeat function for an existing function frame.
Definition function.h:89
#define unlang_function_push(_request, _func, _repeat, _signal, _sigmask, _top_frame, _uctx)
Push a generic function onto the unlang stack.
Definition function.h:111
#define GLOBAL_LIB_TERMINATOR
Definition global_lib.h:51
Structure to define how to initialise libraries with global configuration.
Definition global_lib.h:38
static xlat_action_t ldap_uri_escape_xlat(TALLOC_CTX *ctx, fr_dcursor_t *out, UNUSED xlat_ctx_t const *xctx, request_t *request, fr_value_box_list_t *in)
Escape LDAP string.
Definition rlm_ldap.c:421
static xlat_action_t ldap_xlat(UNUSED TALLOC_CTX *ctx, UNUSED fr_dcursor_t *out, xlat_ctx_t const *xctx, request_t *request, fr_value_box_list_t *in)
Expand an LDAP URL into a query, and return a string result from that query.
Definition rlm_ldap.c:749
static xlat_action_t ldap_group_xlat(TALLOC_CTX *ctx, fr_dcursor_t *out, xlat_ctx_t const *xctx, request_t *request, fr_value_box_list_t *in)
Check for a user being in a LDAP group.
Definition rlm_ldap.c:950
static xlat_action_t ldap_profile_xlat(UNUSED TALLOC_CTX *ctx, UNUSED fr_dcursor_t *out, xlat_ctx_t const *xctx, request_t *request, fr_value_box_list_t *in)
Expand an LDAP URL into a query, applying the results using the user update map.
Definition rlm_ldap.c:1077
static xlat_action_t ldap_uri_unescape_xlat(TALLOC_CTX *ctx, fr_dcursor_t *out, UNUSED xlat_ctx_t const *xctx, request_t *request, fr_value_box_list_t *in)
Unescape LDAP string.
Definition rlm_ldap.c:476
unlang_action_t rlm_ldap_cacheable_userobj(rlm_rcode_t *p_result, request_t *request, ldap_autz_ctx_t *autz_ctx, char const *attr)
Convert group membership information into attributes.
Definition groups.c:443
unlang_action_t rlm_ldap_check_userobj_dynamic(rlm_rcode_t *p_result, request_t *request, ldap_group_xlat_ctx_t *xlat_ctx)
Query the LDAP directory to check if a user object is a member of a group.
Definition groups.c:1120
unlang_action_t rlm_ldap_check_cached(rlm_rcode_t *p_result, rlm_ldap_t const *inst, request_t *request, fr_value_box_t const *check)
Check group membership attributes to see if a user is a member.
Definition groups.c:1158
unlang_action_t rlm_ldap_cacheable_groupobj(rlm_rcode_t *p_result, request_t *request, ldap_autz_ctx_t *autz_ctx)
Convert group membership information into attributes.
Definition groups.c:700
unlang_action_t rlm_ldap_check_groupobj_dynamic(rlm_rcode_t *p_result, request_t *request, ldap_group_xlat_ctx_t *xlat_ctx)
Initiate an LDAP search to determine group membership, querying group objects.
Definition groups.c:786
free(array)
void unlang_interpret_mark_runnable(request_t *request)
Mark a request as resumable.
Definition interpret.c:1360
TALLOC_CTX * unlang_interpret_frame_talloc_ctx(request_t *request)
Get a talloc_ctx which is valid only for this frame.
Definition interpret.c:1405
fr_event_list_t * unlang_interpret_event_list(request_t *request)
Get the event list for the current interpreter.
Definition interpret.c:1757
#define UNLANG_SUB_FRAME
Definition interpret.h:36
char const * fr_ldap_url_err_to_str(int ldap_url_err)
Translate the error code emitted from ldap_url_parse and friends into something accessible with fr_st...
Definition util.c:793
int fr_ldap_map_verify(map_t *map, void *instance)
size_t fr_ldap_uri_unescape_func(UNUSED request_t *request, char *out, size_t outlen, char const *in, UNUSED void *arg))
Converts escaped DNs and filter strings into normal.
Definition util.c:157
size_t fr_ldap_util_normalise_dn(char *out, char const *in)
Normalise escape sequences in a DN.
Definition util.c:490
int fr_ldap_map_getvalue(TALLOC_CTX *ctx, fr_pair_list_t *out, request_t *request, map_t const *map, void *uctx)
Callback for map_to_request.
Definition map.c:39
size_t fr_ldap_uri_escape_func(UNUSED request_t *request, char *out, size_t outlen, char const *in, UNUSED void *arg))
Converts "bad" strings into ones which are safe for LDAP.
Definition util.c:70
int fr_ldap_filter_to_tmpl(TALLOC_CTX *ctx, tmpl_rules_t const *t_rules, char const **sub, size_t sublen, tmpl_t **out))
Combine filters and tokenize to a tmpl.
Definition util.c:568
struct berval ** values
libldap struct containing bv_val (char *) and length bv_len.
Definition base.h:361
fr_ldap_control_t serverctrls[LDAP_MAX_CONTROLS]
Server controls specific to this query.
Definition base.h:450
int fr_ldap_map_do(request_t *request, char const *check_attr, char const *valuepair_attr, fr_ldap_map_exp_t const *expanded, LDAPMessage *entry)
Convert attribute map into valuepairs.
Definition map.c:335
fr_time_delta_t res_timeout
How long we wait for results.
Definition base.h:298
char const * admin_password
Password used in administrative bind.
Definition base.h:231
fr_ldap_config_t * config
Module instance config.
Definition base.h:383
int count
Index on next free element.
Definition base.h:375
bool fr_ldap_util_is_dn(char const *in, size_t inlen)
Check whether a string looks like a DN.
Definition util.c:204
char * server
Initial server to bind to.
Definition base.h:224
static int8_t fr_ldap_bind_auth_cmp(void const *one, void const *two)
Compare two ldap bind auth structures on msgid.
Definition base.h:724
LDAP * handle
libldap handle.
Definition base.h:333
char const * admin_identity
Identity we bind as when we need to query the LDAP directory.
Definition base.h:229
fr_ldap_result_code_t ret
Result code.
Definition base.h:470
bool freeit
Whether the control should be freed after we've finished using it.
Definition base.h:136
fr_rb_tree_t * trunks
Tree of LDAP trunks used by this thread.
Definition base.h:382
trunk_conf_t * trunk_conf
Module trunk config.
Definition base.h:384
trunk_request_t * treq
Trunk request this query is associated with.
Definition base.h:456
fr_ldap_thread_trunk_t * fr_thread_ldap_trunk_get(fr_ldap_thread_t *thread, char const *uri, char const *bind_dn, char const *bind_password, request_t *request, fr_ldap_config_t const *config)
Find a thread specific LDAP connection for a specific URI / bind DN.
Definition connection.c:917
int fr_ldap_server_url_check(fr_ldap_config_t *handle_config, char const *server, CONF_SECTION const *cs)
Check an LDAP server entry in URL format is valid.
Definition util.c:656
char * fr_ldap_berval_to_string(TALLOC_CTX *ctx, struct berval const *in)
Convert a berval to a talloced string.
Definition util.c:441
int count
Number of values.
Definition base.h:363
#define LDAP_MAX_ATTRMAP
Maximum number of mappings between LDAP and FreeRADIUS attributes.
Definition base.h:96
int fr_ldap_box_escape(fr_value_box_t *vb, UNUSED void *uctx)
Definition util.c:110
static int8_t fr_ldap_trunk_cmp(void const *one, void const *two)
Compare two ldap trunk structures on connection URI / DN.
Definition base.h:695
int fr_ldap_server_config_check(fr_ldap_config_t *handle_config, char const *server, CONF_SECTION *cs)
Check an LDAP server config in server:port format is valid.
Definition util.c:752
fr_ldap_connection_t * ldap_conn
LDAP connection this query is running on.
Definition base.h:457
fr_ldap_result_code_t
LDAP query result codes.
Definition base.h:188
@ LDAP_RESULT_TIMEOUT
The query timed out.
Definition base.h:192
@ LDAP_RESULT_SUCCESS
Successfully got LDAP results.
Definition base.h:190
@ LDAP_RESULT_NO_RESULT
No results returned.
Definition base.h:194
@ LDAP_RESULT_BAD_DN
The requested DN does not exist.
Definition base.h:193
fr_ldap_thread_trunk_t * fr_thread_ldap_bind_trunk_get(fr_ldap_thread_t *thread)
Find the thread specific trunk to use for LDAP bind auths.
int fr_ldap_map_expand(TALLOC_CTX *ctx, fr_ldap_map_exp_t *expanded, request_t *request, map_list_t const *maps, char const *generic_attr, char const *check_attr, char const *fallthrough_attr)
Expand values in an attribute map where needed.
Definition map.c:279
#define LDAP_MAX_CONTROLS
Maximum number of client/server controls.
Definition base.h:94
trunk_conf_t * bind_trunk_conf
Trunk config for bind auth trunk.
Definition base.h:385
#define LDAP_VIRTUAL_DN_ATTR
'Virtual' attribute which maps to the DN of the object.
Definition base.h:113
int fr_ldap_parse_url_extensions(LDAPControl **sss, size_t sss_len, char *extensions[])
Parse a subset (just server side sort and virtual list view for now) of LDAP URL extensions.
Definition util.c:302
LDAPMessage * result
Head of LDAP results list.
Definition base.h:468
fr_event_list_t * el
Thread event list for callbacks / timeouts.
Definition base.h:386
LDAPControl * control
LDAP control.
Definition base.h:135
unlang_action_t fr_ldap_edir_get_password(request_t *request, char const *dn, fr_ldap_thread_trunk_t *ttrunk, fr_dict_attr_t const *password_da)
Initiate retrieval of the universal password from Novell eDirectory.
Definition edir.c:295
char const * attrs[LDAP_MAX_ATTRMAP+LDAP_MAP_RESERVED+1]
Reserve some space for access attributes.
Definition base.h:372
fr_ldap_thread_trunk_t * bind_trunk
LDAP trunk used for bind auths.
Definition base.h:387
unlang_action_t fr_ldap_bind_auth_async(request_t *request, fr_ldap_thread_t *thread, char const *bind_dn, char const *password)
Initiate an async LDAP bind for authentication.
Definition bind.c:319
trunk_t * trunk
Connection trunk.
Definition base.h:405
fr_timer_t * ev
Event for timing out the query.
Definition base.h:459
TALLOC_CTX * ctx
Context to allocate new attributes in.
Definition base.h:374
fr_rb_tree_t * binds
Tree of outstanding bind auths.
Definition base.h:388
LDAPURLDesc * ldap_url
parsed URL for current query if the source of the query was a URL.
Definition base.h:426
Holds arguments for async bind auth requests.
Definition base.h:613
Connection configuration.
Definition base.h:221
Tracks the state of a libldap connection handle.
Definition base.h:332
Result of expanding the RHS of a set of maps.
Definition base.h:370
LDAP query structure.
Definition base.h:422
Contains a collection of values.
Definition base.h:360
Holds arguments for the async SASL bind operation.
Definition base.h:506
Thread specific structure to manage LDAP trunk connections.
Definition base.h:381
Thread LDAP trunk structure.
Definition base.h:399
#define FR_LDAP_COMMON_CONF(_conf)
Definition conf.h:19
size_t fr_ldap_scope_len
Definition base.c:75
LDAP * fr_ldap_handle_thread_local(void)
Get a thread local dummy LDAP handle.
Definition base.c:1106
global_lib_autoinst_t fr_libldap_global_config
Definition base.c:134
unlang_action_t fr_ldap_trunk_modify(TALLOC_CTX *ctx, fr_ldap_query_t **out, request_t *request, fr_ldap_thread_trunk_t *ttrunk, char const *dn, LDAPMod *mods[], LDAPControl **serverctrls, LDAPControl **clientctrls)
Run an async modification LDAP query on a trunk connection.
Definition base.c:755
fr_table_num_sorted_t const fr_ldap_tls_require_cert[]
Definition base.c:77
fr_table_num_sorted_t const fr_ldap_dereference[]
Definition base.c:86
fr_ldap_query_t * fr_ldap_search_alloc(TALLOC_CTX *ctx, char const *base_dn, int scope, char const *filter, char const *const *attrs, LDAPControl **serverctrls, LDAPControl **clientctrls)
Allocate a new search object.
Definition base.c:1027
unlang_action_t fr_ldap_trunk_search(TALLOC_CTX *ctx, fr_ldap_query_t **out, request_t *request, fr_ldap_thread_trunk_t *ttrunk, char const *base_dn, int scope, char const *filter, char const *const *attrs, LDAPControl **serverctrls, LDAPControl **clientctrls)
Run an async search LDAP query on a trunk connection.
Definition base.c:709
fr_table_num_sorted_t const fr_ldap_scope[]
Definition base.c:69
#define PERROR(_fmt,...)
Definition log.h:228
#define REXDENT()
Exdent (unindent) R* messages by one level.
Definition log.h:443
#define ROPTIONAL(_l_request, _l_global, _fmt,...)
Use different logging functions depending on whether request is NULL or not.
Definition log.h:528
#define RWDEBUG(fmt,...)
Definition log.h:361
#define RDEBUG_ENABLED3
True if request debug level 1-3 messages are enabled.
Definition log.h:335
#define RDEBUG3(fmt,...)
Definition log.h:343
#define RERROR(fmt,...)
Definition log.h:298
#define DEBUG4(_fmt,...)
Definition log.h:267
#define RPERROR(fmt,...)
Definition log.h:302
#define RPEDEBUG(fmt,...)
Definition log.h:376
#define RINDENT()
Indent R* messages by one level.
Definition log.h:430
int map_afrom_cs(TALLOC_CTX *ctx, map_list_t *out, CONF_SECTION *cs, tmpl_rules_t const *lhs_rules, tmpl_rules_t const *rhs_rules, map_validate_t validate, void *uctx, unsigned int max)
Convert a config section into an attribute map.
Definition map.c:1131
int map_to_request(request_t *request, map_t const *map, radius_map_getvalue_t func, void *ctx)
Convert map_t to fr_pair_t (s) and add them to a request_t.
Definition map.c:1869
talloc_free(reap)
int map_proc_register(TALLOC_CTX *ctx, void const *mod_inst, char const *name, map_proc_func_t evaluate, map_proc_instantiate_t instantiate, size_t inst_size, fr_value_box_safe_for_t literals_safe_for)
Register a map processor.
Definition map_proc.c:125
@ FR_TYPE_TLV
Contains nested attributes.
@ FR_TYPE_STRING
String of printable characters.
@ FR_TYPE_VOID
User data.
@ FR_TYPE_BOOL
A truth value.
@ FR_TYPE_OCTETS
Raw octets.
@ FR_TYPE_GROUP
A grouping of other attributes.
long int ssize_t
unsigned char uint8_t
void * env_data
Per call environment data.
Definition module_ctx.h:44
module_instance_t const * mi
Instance of the module being instantiated.
Definition module_ctx.h:42
void * thread
Thread specific instance data.
Definition module_ctx.h:43
fr_event_list_t * el
Event list to register any IO handlers and timers against.
Definition module_ctx.h:68
module_instance_t * mi
Module instance to detach.
Definition module_ctx.h:57
void * thread
Thread instance data.
Definition module_ctx.h:67
module_instance_t const * mi
Instance of the module being instantiated.
Definition module_ctx.h:64
module_instance_t * mi
Instance of the module being instantiated.
Definition module_ctx.h:51
Temporary structure to hold arguments for module calls.
Definition module_ctx.h:41
Temporary structure to hold arguments for detach calls.
Definition module_ctx.h:56
Temporary structure to hold arguments for instantiation calls.
Definition module_ctx.h:50
Temporary structure to hold arguments for thread_instantiation calls.
Definition module_ctx.h:63
xlat_t * module_rlm_xlat_register(TALLOC_CTX *ctx, module_inst_ctx_t const *mctx, char const *name, xlat_func_t func, fr_type_t return_type)
Definition module_rlm.c:243
module_t common
Common fields presented by all modules.
Definition module_rlm.h:39
fr_pair_t * fr_pair_find_by_da_nested(fr_pair_list_t const *list, fr_pair_t const *prev, fr_dict_attr_t const *da)
Find a pair with a matching fr_dict_attr_t, by walking the nested fr_dict_attr_t tree.
Definition pair.c:774
fr_pair_t * fr_pair_find_by_da(fr_pair_list_t const *list, fr_pair_t const *prev, fr_dict_attr_t const *da)
Find the first pair with a matching da.
Definition pair.c:697
unlang_action_t rlm_ldap_map_profile(fr_ldap_result_code_t *ret, int *applied, rlm_ldap_t const *inst, request_t *request, fr_ldap_thread_trunk_t *ttrunk, char const *dn, int scope, char const *filter, fr_ldap_map_exp_t const *expanded)
Search for and apply an LDAP profile.
Definition profile.c:213
#define fr_assert(_expr)
Definition rad_assert.h:38
#define REDEBUG(fmt,...)
Definition radclient.h:52
#define RDEBUG_ENABLED2()
Definition radclient.h:50
#define RDEBUG2(fmt,...)
Definition radclient.h:54
#define RDEBUG(fmt,...)
Definition radclient.h:53
static void thread_detach(UNUSED void *uctx)
Explicitly cleanup module/xlat resources.
Definition radiusd.c:150
static int thread_instantiate(TALLOC_CTX *ctx, fr_event_list_t *el, UNUSED void *uctx)
Create module and xlat per-thread instances.
Definition radiusd.c:133
static rs_t * conf
Definition radsniff.c:53
#define fr_rb_inline_talloc_alloc(_ctx, _type, _field, _data_cmp, _data_free)
Allocs a red black that verifies elements are of a specific talloc type.
Definition rb.h:246
int fr_rb_flatten_inorder(TALLOC_CTX *ctx, void **out[], fr_rb_tree_t *tree)
#define RETURN_MODULE_NOOP
Definition rcode.h:63
#define RETURN_MODULE_RCODE(_rcode)
Definition rcode.h:66
#define RETURN_MODULE_INVALID
Definition rcode.h:60
#define RETURN_MODULE_FAIL
Definition rcode.h:57
rlm_rcode_t
Return codes indicating the result of the module call.
Definition rcode.h:40
@ RLM_MODULE_INVALID
The module considers the request invalid.
Definition rcode.h:45
@ RLM_MODULE_OK
The module is OK, continue.
Definition rcode.h:43
@ RLM_MODULE_FAIL
Module failed, don't reply.
Definition rcode.h:42
@ RLM_MODULE_DISALLOW
Reject the request (user is locked out).
Definition rcode.h:46
@ RLM_MODULE_REJECT
Immediately reject the request.
Definition rcode.h:41
@ RLM_MODULE_TIMEOUT
Module (or section) timed out.
Definition rcode.h:50
@ RLM_MODULE_NOTFOUND
User not found.
Definition rcode.h:47
@ RLM_MODULE_UPDATED
OK (pairs modified).
Definition rcode.h:49
@ RLM_MODULE_HANDLED
The module handled the request, so stop.
Definition rcode.h:44
tmpl_t const * tmpl
Definition rlm_ldap.c:69
static const call_env_method_t xlat_memberof_method_env
Definition rlm_ldap.c:269
static int mod_detach(module_detach_ctx_t const *mctx)
Detach from the LDAP server and cleanup internal state.
Definition rlm_ldap.c:2193
static int mod_load(void)
Definition rlm_ldap.c:2739
static xlat_action_t ldap_profile_xlat_resume(TALLOC_CTX *ctx, fr_dcursor_t *out, xlat_ctx_t const *xctx, UNUSED request_t *request, UNUSED fr_value_box_list_t *in)
Return whether evaluating the profile was successful.
Definition rlm_ldap.c:1049
map_list_t * profile_map
List of maps to apply to the profile.
Definition rlm_ldap.c:81
#define REPEAT_LDAP_MEMBEROF_XLAT_RESULTS
Definition rlm_ldap.c:870
static conf_parser_t profile_config[]
Definition rlm_ldap.c:97
static int ldap_map_verify(CONF_SECTION *cs, UNUSED void const *mod_inst, UNUSED void *proc_inst, tmpl_t const *src, UNUSED map_list_t const *maps)
Definition rlm_ldap.c:1206
fr_dict_attr_t const * attr_nt_password
Definition rlm_ldap.c:328
static void user_modify_cancel(UNUSED request_t *request, UNUSED fr_signal_t action, void *uctx)
Cancel an in progress user modification.
Definition rlm_ldap.c:1924
static xlat_arg_parser_t const ldap_safe_xlat_arg[]
Definition rlm_ldap.c:412
static unlang_action_t mod_map_proc(rlm_rcode_t *p_result, void const *mod_inst, UNUSED void *proc_inst, request_t *request, fr_value_box_list_t *url, map_list_t const *maps)
Perform a search and map the result of the search to server attributes.
Definition rlm_ldap.c:1352
ldap_auth_call_env_t * call_env
Definition rlm_ldap.c:359
static unlang_action_t ldap_group_xlat_results(rlm_rcode_t *p_result, UNUSED int *priority, request_t *request, void *uctx)
Run the state machine for the LDAP membership xlat.
Definition rlm_ldap.c:880
static const call_env_method_t authenticate_method_env
Definition rlm_ldap.c:190
static unlang_action_t user_modify_mod_build_resume(rlm_rcode_t *p_result, UNUSED int *priority, request_t *request, void *uctx)
Definition rlm_ldap.c:1966
static xlat_arg_parser_t const ldap_uri_escape_xlat_arg[]
Definition rlm_ldap.c:407
fr_ldap_result_code_t ret
Definition rlm_ldap.c:1040
fr_dict_attr_t const * attr_ldap_userdn
Definition rlm_ldap.c:327
global_lib_autoinst_t const * rlm_ldap_lib[]
Definition rlm_ldap.c:346
static const call_env_method_t authorize_method_env
Definition rlm_ldap.c:213
#define USERMOD_ENV(_section)
Definition rlm_ldap.c:254
fr_value_box_t password
Definition rlm_ldap.c:58
static unlang_action_t mod_map_resume(rlm_rcode_t *p_result, UNUSED int *priority, request_t *request, void *uctx)
Process the results of an LDAP map query.
Definition rlm_ldap.c:1226
LDAPControl * serverctrls[LDAP_MAX_CONTROLS]
Definition rlm_ldap.c:387
#define SSS_CONTROL_BUILD(_obj)
static xlat_arg_parser_t const ldap_uri_unescape_xlat_arg[]
Definition rlm_ldap.c:467
static const call_env_method_t xlat_profile_method_env
Definition rlm_ldap.c:298
static int ldap_mod_section_parse(TALLOC_CTX *ctx, call_env_parsed_head_t *out, tmpl_rules_t const *t_rules, CONF_ITEM *ci, call_env_ctx_t const *cec, call_env_parser_t const *rule)
#define CHECK_EXPANDED_SPACE(_expanded)
map_list_t const * maps
Definition rlm_ldap.c:383
static unlang_action_t user_modify_resume(rlm_rcode_t *p_result, UNUSED int *priority, request_t *request, void *uctx)
Take the retrieved user DN and launch the async tmpl expansion of mod_values.
Definition rlm_ldap.c:2105
fr_dict_attr_t const * attr_crypt_password
Definition rlm_ldap.c:326
fr_value_box_t user_filter
Definition rlm_ldap.c:73
static int ldap_group_filter_parse(TALLOC_CTX *ctx, void *out, tmpl_rules_t const *t_rules, CONF_ITEM *ci, call_env_ctx_t const *cec, UNUSED call_env_parser_t const *rule)
static fr_dict_t const * dict_freeradius
Definition rlm_ldap.c:316
static int map_ctx_free(ldap_map_ctx_t *map_ctx)
Ensure map context is properly cleared up.
Definition rlm_ldap.c:1322
fr_dict_attr_t const * cache_da
Definition rlm_ldap.c:54
static void ldap_query_timeout(UNUSED fr_timer_list_t *tl, UNUSED fr_time_t now, void *uctx)
Callback when LDAP query times out.
Definition rlm_ldap.c:542
static conf_parser_t user_config[]
Definition rlm_ldap.c:112
static fr_dict_attr_t const * attr_expr_bool_enum
Definition rlm_ldap.c:330
static fr_table_num_sorted_t const ldap_uri_scheme_table[]
Definition rlm_ldap.c:396
static xlat_arg_parser_t const ldap_xlat_arg[]
Definition rlm_ldap.c:650
static unlang_action_t mod_authorize_start(UNUSED rlm_rcode_t *p_result, UNUSED int *priority, request_t *request, void *uctx)
Start LDAP authorization with async lookup of user DN.
Definition rlm_ldap.c:1515
static int ldap_uri_part_escape(fr_value_box_t *vb, UNUSED void *uctx)
Escape function for a part of an LDAP URI.
Definition rlm_ldap.c:513
fr_dict_attr_t const * group_da
Definition rlm_ldap.c:53
fr_dict_attr_t const * attr_password
Definition rlm_ldap.c:324
static unlang_action_t mod_authenticate(rlm_rcode_t *p_result, module_ctx_t const *mctx, request_t *request)
Definition rlm_ldap.c:1437
static int mod_bootstrap(module_inst_ctx_t const *mctx)
Bootstrap the module.
Definition rlm_ldap.c:2670
#define REPEAT_MOD_AUTHORIZE_RESUME
Definition rlm_ldap.c:1524
fr_value_box_t user_sasl_proxy
Definition rlm_ldap.c:62
fr_ldap_thread_trunk_t * ttrunk
Definition rlm_ldap.c:371
fr_value_box_t user_sasl_authname
Definition rlm_ldap.c:61
fr_dict_attr_t const * attr_password_with_header
Definition rlm_ldap.c:329
static int ldap_update_section_parse(TALLOC_CTX *ctx, call_env_parsed_head_t *out, tmpl_rules_t const *t_rules, CONF_ITEM *ci, call_env_ctx_t const *cec, call_env_parser_t const *rule)
rlm_ldap_t const * inst
Definition rlm_ldap.c:366
static conf_parser_t group_config[]
Definition rlm_ldap.c:128
fr_ldap_query_t * query
Definition rlm_ldap.c:385
static void mod_unload(void)
Definition rlm_ldap.c:2760
fr_dict_attr_autoload_t rlm_ldap_dict_attr[]
Definition rlm_ldap.c:333
ldap_mod_tmpl_t ** mod
Definition rlm_ldap.c:74
static xlat_action_t ldap_group_xlat_resume(TALLOC_CTX *ctx, fr_dcursor_t *out, xlat_ctx_t const *xctx, UNUSED request_t *request, UNUSED fr_value_box_list_t *in)
Process the results of evaluating LDAP group membership.
Definition rlm_ldap.c:928
char const * attr
Definition rlm_ldap.c:67
static void ldap_group_xlat_cancel(UNUSED request_t *request, UNUSED fr_signal_t action, void *uctx)
Cancel an in-progress query for the LDAP group membership xlat.
Definition rlm_ldap.c:861
ssize_t expect_password_offset
Definition rlm_ldap.c:210
static int ldap_xlat_uri_parse(LDAPURLDesc **uri_parsed, char **host_out, bool *free_host_out, request_t *request, char *host_default, fr_value_box_t *uri_in)
Utility function for parsing LDAP URLs.
Definition rlm_ldap.c:690
static int ldap_xlat_profile_ctx_free(ldap_xlat_profile_ctx_t *to_free)
Definition rlm_ldap.c:1062
static char * host_uri_canonify(request_t *request, LDAPURLDesc *url_parsed, fr_value_box_t *url_in)
Produce canonical LDAP host URI for finding trunks.
Definition rlm_ldap.c:659
fr_dict_attr_t const * attr_cleartext_password
Definition rlm_ldap.c:325
tmpl_t const * password_tmpl
Definition rlm_ldap.c:59
static unlang_action_t mod_authorize(rlm_rcode_t *p_result, module_ctx_t const *mctx, request_t *request)
Definition rlm_ldap.c:1844
static xlat_action_t ldap_xlat_resume(TALLOC_CTX *ctx, fr_dcursor_t *out, xlat_ctx_t const *xctx, request_t *request, UNUSED fr_value_box_list_t *in)
Callback when resuming after async ldap query is completed.
Definition rlm_ldap.c:568
fr_value_box_t user_sasl_mech
Definition rlm_ldap.c:60
static unlang_action_t user_modify_start(UNUSED rlm_rcode_t *p_result, UNUSED int *priority, request_t *request, void *uctx)
Perform async lookup of user DN if required for user modification.
Definition rlm_ldap.c:1912
fr_dict_autoload_t rlm_ldap_dict[]
Definition rlm_ldap.c:319
static int mod_thread_instantiate(module_thread_inst_ctx_t const *mctx)
Initialise thread specific data structure.
Definition rlm_ldap.c:2413
module_rlm_t rlm_ldap
Definition rlm_ldap.c:2769
char const * password
Definition rlm_ldap.c:356
static int autz_ctx_free(ldap_autz_ctx_t *autz_ctx)
Ensure authorization context is properly cleared up.
Definition rlm_ldap.c:1837
ldap_schemes_t
Definition rlm_ldap.c:390
@ LDAP_SCHEME_UNIX
Definition rlm_ldap.c:391
@ LDAP_SCHEME_TCP_SSL
Definition rlm_ldap.c:393
@ LDAP_SCHEME_TCP
Definition rlm_ldap.c:392
fr_token_t op
Definition rlm_ldap.c:68
fr_value_box_t user_base
Definition rlm_ldap.c:72
fr_ldap_map_exp_t expanded
Definition rlm_ldap.c:1043
static unlang_action_t ldap_group_xlat_user_find(UNUSED rlm_rcode_t *p_result, UNUSED int *priority, request_t *request, void *uctx)
User object lookup as part of group membership xlat.
Definition rlm_ldap.c:845
static void ldap_xlat_signal(xlat_ctx_t const *xctx, request_t *request, UNUSED fr_signal_t action)
Callback for signalling async ldap query.
Definition rlm_ldap.c:615
fr_ldap_query_t * query
Definition rlm_ldap.c:372
static unlang_action_t mod_modify(rlm_rcode_t *p_result, module_ctx_t const *mctx, request_t *request)
Modify user's object in LDAP.
Definition rlm_ldap.c:2142
fr_ldap_thread_t * thread
Definition rlm_ldap.c:358
static size_t ldap_uri_scheme_table_len
Definition rlm_ldap.c:401
#define LDAP_URI_SAFE_FOR
This is the common function that actually ends up doing all the URI escaping.
Definition rlm_ldap.c:405
static fr_uri_part_t const ldap_dn_parts[]
Definition rlm_ldap.c:645
static unlang_action_t user_modify_final(rlm_rcode_t *p_result, UNUSED int *priority, request_t *request, void *uctx)
Handle results of user modification.
Definition rlm_ldap.c:1936
static const conf_parser_t module_config[]
Definition rlm_ldap.c:145
#define USER_CALL_ENV_COMMON(_struct)
Definition rlm_ldap.c:186
ldap_usermod_call_env_t * call_env
Definition rlm_ldap.c:367
static unlang_action_t mod_authorize_resume(rlm_rcode_t *p_result, UNUSED int *priority, request_t *request, void *uctx)
Resume function called after each potential yield in LDAP authorization.
Definition rlm_ldap.c:1543
static void mod_authorize_cancel(UNUSED request_t *request, UNUSED fr_signal_t action, void *uctx)
Clear up when cancelling a mod_authorize call.
Definition rlm_ldap.c:1827
fr_value_box_t profile_filter
Filter to use when searching for users.
Definition rlm_ldap.c:80
static int mod_thread_detach(module_thread_inst_ctx_t const *mctx)
Clean up thread specific data structure.
Definition rlm_ldap.c:2395
static int mod_instantiate(module_inst_ctx_t const *mctx)
Instantiate the module.
Definition rlm_ldap.c:2458
fr_ldap_map_exp_t expanded
Definition rlm_ldap.c:386
LDAPURLDesc * ldap_url
Definition rlm_ldap.c:384
static const call_env_parser_t sasl_call_env[]
Definition rlm_ldap.c:89
fr_value_box_t user_sasl_realm
Definition rlm_ldap.c:63
fr_value_box_list_t expanded
Definition rlm_ldap.c:373
static fr_uri_part_t const ldap_uri_parts[]
Definition rlm_ldap.c:633
char const * dn
Definition rlm_ldap.c:355
static xlat_arg_parser_t const ldap_group_xlat_arg[]
Definition rlm_ldap.c:941
rlm_ldap_t const * inst
Definition rlm_ldap.c:357
Holds state of in progress async authentication.
Definition rlm_ldap.c:354
Holds state of in progress LDAP map.
Definition rlm_ldap.c:382
Parameters to allow ldap_update_section_parse to be reused.
Definition rlm_ldap.c:208
Holds state of in progress ldap user modifications.
Definition rlm_ldap.c:365
Call environment used in the profile xlat.
Definition rlm_ldap.c:79
LDAP authorization and authentication module headers.
fr_ldap_map_exp_t expanded
Definition rlm_ldap.h:194
ldap_autz_call_env_t * call_env
Definition rlm_ldap.h:197
struct berval ** profile_values
Definition rlm_ldap.h:200
@ LDAP_ACCESS_SUSPENDED
User account has been suspended.
Definition rlm_ldap.h:185
@ LDAP_ACCESS_ALLOWED
User is allowed to login.
Definition rlm_ldap.h:183
@ LDAP_ACCESS_DISALLOWED
User it not allow to login (disabled)
Definition rlm_ldap.h:184
fr_ldap_thread_trunk_t * ttrunk
Definition rlm_ldap.h:196
rlm_ldap_t const * inst
Definition rlm_ldap.h:193
fr_value_box_t profile_filter
Filter to use when searching for profiles.
Definition rlm_ldap.h:144
fr_value_box_t user_filter
Filter to use when searching for users.
Definition rlm_ldap.h:137
LDAPMessage * entry
Definition rlm_ldap.h:198
@ LDAP_AUTZ_GROUP
Definition rlm_ldap.h:167
@ LDAP_AUTZ_FIND
Definition rlm_ldap.h:166
@ LDAP_AUTZ_DEFAULT_PROFILE
Definition rlm_ldap.h:174
@ LDAP_AUTZ_USER_PROFILE
Definition rlm_ldap.h:176
@ LDAP_AUTZ_MAP
Definition rlm_ldap.h:173
@ LDAP_AUTZ_POST_DEFAULT_PROFILE
Definition rlm_ldap.h:175
@ LDAP_AUTZ_POST_GROUP
Definition rlm_ldap.h:168
ldap_autz_status_t status
Definition rlm_ldap.h:199
fr_ldap_query_t * query
Definition rlm_ldap.h:195
char * profile_value
Definition rlm_ldap.h:202
ldap_access_state_t access_state
What state a user's account is in.
Definition rlm_ldap.h:204
fr_value_box_t user_base
Base DN in which to search for users.
Definition rlm_ldap.h:136
unlang_action_t rlm_ldap_find_user_async(TALLOC_CTX *ctx, rlm_ldap_t const *inst, request_t *request, fr_value_box_t *base, fr_value_box_t *filter_box, fr_ldap_thread_trunk_t *ttrunk, char const *attrs[], fr_ldap_query_t **query_out)
Initiate asynchronous retrieval of the DN of a user object.
Definition user.c:159
char const * dn
Definition rlm_ldap.h:203
map_list_t * user_map
Attribute map applied to users and profiles.
Definition rlm_ldap.h:146
static char const * rlm_find_user_dn_cached(request_t *request)
Definition rlm_ldap.h:246
void rlm_ldap_check_reply(request_t *request, rlm_ldap_t const *inst, char const *inst_name, bool expect_password, fr_ldap_thread_trunk_t const *ttrunk)
Verify we got a password from the search.
Definition user.c:251
fr_value_box_t const * expect_password
True if the user_map included a mapping between an LDAP attribute and one of our password reference a...
Definition rlm_ldap.h:148
fr_value_box_t default_profile
If this is set, we will search for a profile object with this name, and map any attributes it contain...
Definition rlm_ldap.h:140
@ GROUP_XLAT_MEMB_FILTER
Definition rlm_ldap.h:211
@ GROUP_XLAT_MEMB_ATTR
Definition rlm_ldap.h:212
@ GROUP_XLAT_FIND_USER
Definition rlm_ldap.h:210
module_instance_t const * dlinst
Definition rlm_ldap.h:192
ldap_access_state_t rlm_ldap_check_access(rlm_ldap_t const *inst, request_t *request, LDAPMessage *entry)
Check for presence of access attribute in result.
Definition user.c:199
Call environment used in LDAP authorization.
Definition rlm_ldap.h:135
Holds state of in progress async authorization.
Definition rlm_ldap.h:191
Holds state of in progress group membership check xlat.
Definition rlm_ldap.h:218
Call environment used in group membership xlat.
Definition rlm_ldap.h:155
unlang_action_t fr_ldap_sasl_bind_auth_async(request_t *request, fr_ldap_thread_t *thread, char const *mechs, char const *identity, char const *password, char const *proxy, char const *realm)
Initiate an async SASL LDAP bind for authentication.
Definition sasl.c:504
int fr_sbuff_trim_talloc(fr_sbuff_t *sbuff, size_t len)
Trim a talloced sbuff to the minimum length required to represent the contained string.
Definition sbuff.c:421
#define FR_SBUFF_IN(_start, _len_or_end)
#define FR_SBUFF_TERMS(...)
Initialise a terminal structure with a list of sorted strings.
Definition sbuff.h:192
#define fr_sbuff_buff(_sbuff_or_marker)
Talloc sbuff extension structure.
Definition sbuff.h:139
static char const * section_name_str(char const *name)
Return a printable string for the section name.
Definition section.h:98
#define SECTION_NAME(_name1, _name2)
Define a section name consisting of a verb and a noun.
Definition section.h:40
char const * name2
Second section name. Usually a packet type like 'access-request', 'access-accept',...
Definition section.h:46
char const * name1
First section name. Usually a verb like 'recv', 'send', etc...
Definition section.h:45
char const * name
Instance name e.g. user_database.
Definition module.h:336
module_flags_t flags
Flags that control how a module starts up and how a module is called.
Definition module.h:228
CONF_SECTION * conf
Module's instance configuration.
Definition module.h:330
void * data
Module's instance data.
Definition module.h:272
void * boot
Data allocated during the boostrap phase.
Definition module.h:275
void * data
Thread specific instance data.
Definition module.h:353
static module_thread_instance_t * module_thread(module_instance_t const *mi)
Retrieve module/thread specific instance for a module.
Definition module.h:482
#define MODULE_BINDING_TERMINATOR
Terminate a module binding list.
Definition module.h:151
Named methods exported by a module.
Definition module.h:173
static tmpl_attr_t const * tmpl_attr_tail(tmpl_t const *vpt)
Return the last attribute reference.
Definition tmpl.h:790
int tmpl_resolve(tmpl_t *vpt, tmpl_res_rules_t const *tr_rules))
Attempt to resolve functions and attributes in xlats and attribute references.
ssize_t tmpl_afrom_substr(TALLOC_CTX *ctx, tmpl_t **out, fr_sbuff_t *in, fr_token_t quote, fr_sbuff_parse_rules_t const *p_rules, tmpl_rules_t const *t_rules))
Convert an arbitrary string into a tmpl_t.
tmpl_attr_rules_t attr
Rules/data for parsing attribute references.
Definition tmpl.h:335
#define tmpl_needs_resolving(vpt)
Definition tmpl.h:223
Similar to tmpl_rules_t, but used to specify parameters that may change during subsequent resolution ...
Definition tmpl.h:364
Optional arguments passed to vp_tmpl functions.
Definition tmpl.h:332
fr_signal_t
Signals that can be generated/processed by request signal handlers.
Definition signal.h:38
@ FR_SIGNAL_CANCEL
Request has been cancelled.
Definition signal.h:40
PUBLIC int snprintf(char *string, size_t length, char *format, va_alist)
Definition snprintf.c:689
return count
Definition module.c:155
eap_aka_sim_process_conf_t * inst
Value pair map.
Definition map.h:77
tmpl_t * lhs
Typically describes the attribute to add, modify or compare.
Definition map.h:78
fr_dict_t const * dict_def
Default dictionary to use with unqualified attribute references.
Definition tmpl.h:273
An element in a list of nested attribute references.
Definition tmpl.h:430
fr_dict_attr_t const *_CONST da
Resolved dictionary attribute.
Definition tmpl.h:434
Stores an attribute, a value and various bits of other data.
Definition pair.h:68
#define fr_table_value_by_str(_table, _name, _def)
Convert a string to a value using a sorted or ordered table.
Definition table.h:653
#define fr_table_str_by_value(_table, _number, _def)
Convert an integer to a string.
Definition table.h:772
An element in a lexicographically sorted array of name to num mappings.
Definition table.h:49
char * talloc_typed_strdup_buffer(TALLOC_CTX *ctx, char const *p)
Call talloc_strndup, setting the type on the new chunk correctly.
Definition talloc.c:491
char * talloc_typed_asprintf(TALLOC_CTX *ctx, char const *fmt,...)
Call talloc vasprintf, setting the type on the new chunk correctly.
Definition talloc.c:514
#define talloc_get_type_abort_const
Definition talloc.h:287
#define talloc_pooled_object(_ctx, _type, _num_subobjects, _total_subobjects_size)
Definition talloc.h:180
"server local" time.
Definition time.h:69
An event timer list.
Definition timer.c:50
#define fr_timer_in(...)
Definition timer.h:87
int unlang_tmpl_push(TALLOC_CTX *ctx, fr_value_box_list_t *out, request_t *request, tmpl_t const *tmpl, unlang_tmpl_args_t *args)
Push a tmpl onto the stack for evaluation.
Definition tmpl.c:260
@ TMPL_ESCAPE_PRE_CONCAT
Pre-concatenation escaping is useful for DSLs where elements of the expansion are static,...
Definition tmpl_escape.h:61
fr_table_num_ordered_t const fr_tokens_table[]
Definition token.c:34
enum fr_token fr_token_t
@ T_OP_SUB_EQ
Definition token.h:70
@ T_SINGLE_QUOTED_STRING
Definition token.h:122
@ T_BARE_WORD
Definition token.h:120
@ T_OP_SET
Definition token.h:84
@ T_OP_ADD_EQ
Definition token.h:69
@ T_OP_CMP_FALSE
Definition token.h:105
@ T_OP_INCRM
Definition token.h:113
trunk_enqueue_t trunk_request_enqueue(trunk_request_t **treq_out, trunk_t *trunk, request_t *request, void *preq, void *rctx)
Enqueue a request that needs data written to the trunk.
Definition trunk.c:2586
void trunk_request_signal_cancel(trunk_request_t *treq)
Cancel a trunk request.
Definition trunk.c:2151
conf_parser_t const trunk_config[]
Config parser definitions to populate a trunk_conf_t.
Definition trunk.c:314
Wraps a normal request.
Definition trunk.c:99
@ TRUNK_ENQUEUE_OK
Operation was successful.
Definition trunk.h:150
@ TRUNK_ENQUEUE_IN_BACKLOG
Request should be enqueued in backlog.
Definition trunk.h:149
xlat_action_t unlang_xlat_yield(request_t *request, xlat_func_t resume, xlat_func_signal_t signal, fr_signal_t sigmask, void *rctx)
Yield a request back to the interpreter from within a module.
Definition xlat.c:567
xlat_action_t xlat_transparent(UNUSED TALLOC_CTX *ctx, fr_dcursor_t *out, UNUSED xlat_ctx_t const *xctx, request_t *request, fr_value_box_list_t *args)
uint8_t required
Argument must be present, and non-empty.
Definition xlat.h:145
#define XLAT_ARGS(_list,...)
Populate local variables with value boxes from the input list.
Definition xlat.h:382
#define XLAT_ARG_PARSER_TERMINATOR
Definition xlat.h:169
xlat_action_t
Definition xlat.h:37
@ XLAT_ACTION_FAIL
An xlat function failed.
Definition xlat.h:44
@ XLAT_ACTION_YIELD
An xlat function pushed a resume frame onto the stack.
Definition xlat.h:42
@ XLAT_ACTION_PUSH_UNLANG
An xlat function pushed an unlang frame onto the unlang stack.
Definition xlat.h:39
@ XLAT_ACTION_DONE
We're done evaluating this level of nesting.
Definition xlat.h:43
Definition for a single argument consumend by an xlat function.
Definition xlat.h:144
int fr_uri_escape_list(fr_value_box_list_t *uri, fr_uri_part_t const *uri_parts, void *uctx)
Parse a list of value boxes representing a URI.
Definition uri.c:140
int fr_uri_has_scheme(fr_value_box_list_t *uri, fr_table_num_sorted_t const *schemes, size_t schemes_len, int def)
Searches for a matching scheme in the table of schemes, using a list of value boxes representing the ...
Definition uri.c:167
#define XLAT_URI_PART_TERMINATOR
Definition uri.h:66
char const * name
Name of this part of the URI.
Definition uri.h:47
Definition for a single part of a URI.
Definition uri.h:46
#define fr_strerror_printf_push(_fmt,...)
Add a message to an existing stack of messages at the tail.
Definition strerror.h:84
#define FR_TYPE_FIXED_SIZE
Definition types.h:306
fr_sbuff_parse_rules_t const * value_parse_rules_quoted[T_TOKEN_LAST]
Parse rules for quoted strings.
Definition value.c:605
int fr_value_box_copy(TALLOC_CTX *ctx, fr_value_box_t *dst, const fr_value_box_t *src)
Copy value data verbatim duplicating any buffers.
Definition value.c:3962
int fr_value_box_cast_in_place(TALLOC_CTX *ctx, fr_value_box_t *vb, fr_type_t dst_type, fr_dict_attr_t const *dst_enumv)
Convert one type of fr_value_box_t to another in place.
Definition value.c:3790
void fr_value_box_strdup_shallow_replace(fr_value_box_t *vb, char const *src, ssize_t len)
Free the existing buffer (if talloced) associated with the valuebox, and replace it with a new one.
Definition value.c:4283
void fr_value_box_strdup_shallow(fr_value_box_t *dst, fr_dict_attr_t const *enumv, char const *src, bool tainted)
Assign a buffer containing a nul terminated string to a box, but don't copy it.
Definition value.c:4267
int fr_value_box_bstr_realloc(TALLOC_CTX *ctx, char **out, fr_value_box_t *dst, size_t len)
Change the length of a buffer already allocated to a value box.
Definition value.c:4335
int fr_value_box_bstrndup(TALLOC_CTX *ctx, fr_value_box_t *dst, fr_dict_attr_t const *enumv, char const *src, size_t len, bool tainted)
Copy a string to to a fr_value_box_t.
Definition value.c:4379
int fr_value_box_bstrdup_buffer_shallow(TALLOC_CTX *ctx, fr_value_box_t *dst, fr_dict_attr_t const *enumv, char const *src, bool tainted)
Assign a talloced buffer containing a nul terminated string to a box, but don't copy it.
Definition value.c:4484
int fr_value_box_list_concat_in_place(TALLOC_CTX *ctx, fr_value_box_t *out, fr_value_box_list_t *list, fr_type_t type, fr_value_box_list_action_t proc_action, bool flatten, size_t max_size)
Concatenate a list of value boxes.
Definition value.c:5949
@ FR_VALUE_BOX_LIST_FREE
Definition value.h:237
#define fr_value_box_alloc(_ctx, _type, _enumv)
Allocate a value box of a specific type.
Definition value.h:640
#define fr_value_box_is_safe_for_only(_box, _safe_for)
Definition value.h:1079
#define fr_box_strvalue_len(_val, _len)
Definition value.h:305
uintptr_t fr_value_box_safe_for_t
Escaping that's been applied to a value box.
Definition value.h:160
int nonnull(2, 5))
#define fr_value_box_alloc_null(_ctx)
Allocate a value box for later use with a value assignment function.
Definition value.h:651
static size_t char ** out
Definition value.h:1020
static TALLOC_CTX * xlat_ctx
void * rctx
Resume context.
Definition xlat_ctx.h:54
void * env_data
Expanded call env data.
Definition xlat_ctx.h:53
module_ctx_t const * mctx
Synthesised module calling ctx.
Definition xlat_ctx.h:52
An xlat calling ctx.
Definition xlat_ctx.h:49
void xlat_func_flags_set(xlat_t *x, xlat_func_flags_t flags)
Specify flags that alter the xlat's behaviour.
Definition xlat_func.c:399
int xlat_func_args_set(xlat_t *x, xlat_arg_parser_t const args[])
Register the arguments of an xlat.
Definition xlat_func.c:363
void xlat_func_call_env_set(xlat_t *x, call_env_method_t const *env_method)
Register call environment of an xlat.
Definition xlat_func.c:389
xlat_t * xlat_func_register(TALLOC_CTX *ctx, char const *name, xlat_func_t func, fr_type_t return_type)
Register an xlat function.
Definition xlat_func.c:216
void xlat_func_unregister(char const *name)
Unregister an xlat function.
Definition xlat_func.c:516
#define xlat_func_safe_for_set(_xlat, _escaped)
Set the escaped values for output boxes.
Definition xlat_func.h:82
@ XLAT_FUNC_FLAG_PURE
Definition xlat_func.h:38