diff --git a/src/mod/xml_int/mod_xml_ldap/mod_xml_ldap.c b/src/mod/xml_int/mod_xml_ldap/mod_xml_ldap.c index b85818dc45..2838eeba0e 100644 --- a/src/mod/xml_int/mod_xml_ldap/mod_xml_ldap.c +++ b/src/mod/xml_int/mod_xml_ldap/mod_xml_ldap.c @@ -34,484 +34,611 @@ #include #include #include -#ifdef MSLDAP -#include -#include -#include -#define LDAP_OPT_SUCCESS LDAP_SUCCESS -#else #include #include -#include -#include "lutil_ldap.h" -#endif + +#define PCACHE_TTL 300 +#define NCACHE_TTL 900 + +typedef struct xml_ldap_attribute xml_ldap_attribute_t; + typedef enum { XML_LDAP_CONFIG = 0, XML_LDAP_DIRECTORY, XML_LDAP_DIALPLAN, - XML_LDAP_PHRASE, - XML_LDAP_LANGUAGE + XML_LDAP_PHRASE } xml_ldap_query_type_t; -SWITCH_MODULE_LOAD_FUNCTION(mod_xml_ldap_load); -SWITCH_MODULE_SHUTDOWN_FUNCTION(mod_xml_ldap_shutdown); -SWITCH_MODULE_DEFINITION(mod_xml_ldap, mod_xml_ldap_load, mod_xml_ldap_shutdown, NULL); typedef struct xml_binding { char *bindings; - char *host; + xml_ldap_query_type_t bt; + char *url; char *basedn; char *binddn; char *bindpass; char *filter; - char **attrs; - lutilSASLdefaults *defaults; + xml_ldap_attribute_t *attr_list; } xml_binding_t; -typedef struct ldap_c { - LDAP *ld; - LDAPMessage *msg; - LDAPMessage *entry; - BerElement *berkey; - BerElement *berval; - char *key; - char *val; - char **keyvals; - char **valvals; - char *sp; -} ldap_ctx; +typedef enum exten_types { + LDAP_EXTEN_ID = 0, + LDAP_EXTEN_CIDR, + LDAP_EXTEN_PASSWORD, + LDAP_EXTEN_VM_ENABLED, + LDAP_EXTEN_VM_PASSWORD, + LDAP_EXTEN_VM_MAILFROM, + LDAP_EXTEN_VM_MAILTO, + LDAP_EXTEN_VM_EMAILMSG, + LDAP_EXTEN_VM_NOTEMAILMSG, + LDAP_EXTEN_VM_ATTACHFILE, + LDAP_EXTEN_USER_CONTEXT, + LDAP_EXTEN_EFF_CLIDNAME, + LDAP_EXTEN_EFF_CLIDNUM, + LDAP_EXTEN_ACCOUNTCODE, + LDAP_EXTEN_RULESET, + LDAP_EXTEN_AREACODE, + LDAP_EXTEN_CID_EXTNAME, + LDAP_EXTEN_CID_EXTNUM, + LDAP_EXTEN_INTNAME, + LDAP_EXTEN_INTNUM, + LDAP_EXTEN_RECORD_CALLS, + LDAP_EXTEN_ACTIVE, + LDAP_EXTEN_CFWD_REWRITECID, + LDAP_EXTEN_CFWD_ACTIVE, + LDAP_EXTEN_CFWD_DEST, + LDAP_EXTEN_CFWD_BUSYACTIVE, + LDAP_EXTEN_CFWD_BUSYDEST, + LDAP_EXTEN_NOANSWERACTIVE, + LDAP_EXTEN_NOANSWERDEST, + LDAP_EXTEN_NOANSWERSECONDS, + LDAP_EXTEN_PROGRESSAUDIO, + LDAP_EXTEN_ALLOW_OUTBOUND, + LDAP_EXTEN_ALLOW_XFER, + LDAP_EXTEN_HOTLINE_ACTIVE, + LDAP_EXTEN_HOTLINE_DEST, + LDAP_EXTEN_CLASSOFSERVICE +} exten_type_t; -static switch_status_t xml_ldap_directory_result(void *ldap_connection, xml_binding_t *binding, switch_xml_t *xml, int *off); -static switch_status_t xml_ldap_dialplan_result(void *ldap_connection, xml_binding_t *binding, switch_xml_t *xml, int *off); - - -#define XML_LDAP_SYNTAX "[debug_on|debug_off]" - -SWITCH_STANDARD_API(xml_ldap_function) -{ - if (session) { - return SWITCH_STATUS_FALSE; - } - - if (zstr(cmd)) { - goto usage; - } - - if (!strcasecmp(cmd, "debug_on")) { - } else if (!strcasecmp(cmd, "debug_off")) { - } else { - goto usage; - } - - stream->write_function(stream, "OK\n"); - return SWITCH_STATUS_SUCCESS; - - usage: - stream->write_function(stream, "USAGE: %s\n", XML_LDAP_SYNTAX); - return SWITCH_STATUS_SUCCESS; -} - -static switch_status_t xml_ldap_result(void *ldap_connection, xml_binding_t *binding, switch_xml_t *xml, int *off, - const xml_ldap_query_type_t query_type) -{ - switch (query_type) { - case XML_LDAP_DIRECTORY: - return xml_ldap_directory_result(ldap_connection, binding, xml, off); - - case XML_LDAP_DIALPLAN: - return xml_ldap_dialplan_result(ldap_connection, binding, xml, off); - - default: - return SWITCH_STATUS_FALSE; - } -} - -static switch_status_t xml_ldap_dialplan_result(void *ldap_connection, xml_binding_t *binding, switch_xml_t *xml, int *off) -{ - return SWITCH_STATUS_FALSE; -} - -static switch_status_t xml_ldap_directory_result(void *ldap_connection, xml_binding_t *binding, switch_xml_t *xml, int *off) -{ - struct ldap_c *ldap = ldap_connection; - switch_xml_t asdf = *xml; - switch_xml_t param, variable, params = NULL, variables = NULL; - int i = 0; - int loff = *off; - - for (ldap->entry = ldap_first_entry(ldap->ld, ldap->msg); ldap->entry != NULL; ldap->entry = ldap_next_entry(ldap->ld, ldap->entry)) { - ldap->key = ldap_first_attribute(ldap->ld, ldap->entry, &ldap->berkey); - do { - ldap->val = ldap_first_attribute(ldap->ld, ldap->entry, &ldap->berval); - do { - if (strstr(ldap->val, "value")) { - if (strstr(ldap->val, ldap->key) && strcmp(ldap->val, ldap->key)) { - if (!strcmp(ldap->key, "param")) { - params = switch_xml_add_child_d(asdf, "params", loff++); - } else if (!strcmp(ldap->key, "variable")) { - variables = switch_xml_add_child_d(asdf, "variables", loff++); - } - - ldap->keyvals = ldap_get_values(ldap->ld, ldap->entry, ldap->key); - ldap->valvals = ldap_get_values(ldap->ld, ldap->entry, ldap->val); - - if (ldap->keyvals && ldap->valvals) { - if (ldap_count_values(ldap->valvals) == ldap_count_values(ldap->keyvals)) { - for (i = 0; ldap->keyvals[i] != NULL && ldap->valvals[i] != NULL; i++) { - if (!strcmp(ldap->key, "param")) { - param = switch_xml_add_child_d(params, "param", loff++); - switch_xml_set_attr_d(param, "name", ldap->keyvals[i]); - switch_xml_set_attr_d(param, "value", ldap->valvals[i]); - } else if (!strcmp(ldap->key, "variable")) { - variable = switch_xml_add_child_d(variables, "variable", loff++); - switch_xml_set_attr_d(variable, "name", ldap->keyvals[i]); - switch_xml_set_attr_d(variable, "value", ldap->valvals[i]); - } - } - - if (ldap->keyvals) { - ldap_value_free(ldap->keyvals); - } - - if (ldap->valvals) { - ldap_value_free(ldap->valvals); - } - } else { - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "Seems the values %d and %d are not the same??\n", - ldap_count_values(ldap->valvals), ldap_count_values(ldap->keyvals)); - } - } - } - } - if (ldap->val) { - ldap_memfree(ldap->val); - } - - ldap->val = ldap_next_attribute(ldap->ld, ldap->entry, ldap->berval); - - } while (ldap->val != NULL); - - if (ldap->key) { - ldap_memfree(ldap->key); - } - - if (ldap->berval) { - ber_free(ldap->berval, 0); - } - - ldap->key = ldap_next_attribute(ldap->ld, ldap->entry, ldap->berkey); - - } while (ldap->key != NULL); - - if (ldap->berkey) { - ber_free(ldap->berkey, 0); - } - } - return SWITCH_STATUS_SUCCESS; -} +struct xml_ldap_attribute { + exten_type_t type; + uint64_t len; + char *val; + xml_ldap_attribute_t *next; +}; + +SWITCH_MODULE_LOAD_FUNCTION(mod_xml_ldap_load); +SWITCH_MODULE_SHUTDOWN_FUNCTION(mod_xml_ldap_shutdown); +SWITCH_MODULE_DEFINITION(mod_xml_ldap, mod_xml_ldap_load, mod_xml_ldap_shutdown, NULL); static switch_xml_t xml_ldap_search(const char *section, const char *tag_name, const char *key_name, const char *key_value, switch_event_t *params, - void *user_data) + void *user_data); + +static switch_status_t trydir(switch_xml_t *, int *, LDAP *, char *, char *, xml_binding_t *); +static switch_status_t do_config(void); +static switch_status_t trysearch(switch_xml_t *pxml, int *xoff, LDAP * ld, char *basedn, char *filter); +void rec(switch_xml_t *, int *, LDAP * ld, char *); + +#define XML_LDAP_SYNTAX "" + +SWITCH_STANDARD_API(xml_ldap_function) { - xml_binding_t *binding = (xml_binding_t *) user_data; - switch_event_header_t *hi; - - switch_xml_t xml = NULL, sub = NULL; - - struct ldap_c ldap_connection; - struct ldap_c *ldap = &ldap_connection; - - int auth_method = LDAP_AUTH_SIMPLE; - int desired_version = LDAP_VERSION3; - xml_ldap_query_type_t query_type; - char *dir_exten = NULL, *dir_domain = NULL; - - char *search_filter = NULL, *search_base = NULL; - int off = 0, ret = 1; - - //char *buf; - //buf = malloc(4096); - - - if (!binding) { - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "No bindings...sorry bud returning now\n"); - return NULL; - } - - if (!strcmp(section, "configuration")) { - query_type = XML_LDAP_CONFIG; - } else if (!strcmp(section, "directory")) { - query_type = XML_LDAP_DIRECTORY; - } else if (!strcmp(section, "dialplan")) { - query_type = XML_LDAP_DIALPLAN; - } else if (!strcmp(section, "phrases")) { - query_type = XML_LDAP_PHRASE; - } else if (!strcmp(section, "languages")) { - query_type = XML_LDAP_LANGUAGE; - } else { - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "Invalid section\n"); - return NULL; - } - - if (params) { - if ((hi = params->headers)) { - for (; hi; hi = hi->next) { - switch (query_type) { - case XML_LDAP_CONFIG: - break; - - case XML_LDAP_DIRECTORY: - if (!strcmp(hi->name, "user")) { - dir_exten = strdup(hi->value); - } else if (!strcmp(hi->name, "domain")) { - dir_domain = strdup(hi->value); - } - break; - - case XML_LDAP_DIALPLAN: - case XML_LDAP_PHRASE: - case XML_LDAP_LANGUAGE: - break; - } - } - switch (query_type) { - case XML_LDAP_CONFIG: - break; - - case XML_LDAP_DIRECTORY: - if (dir_exten && dir_domain) { - if ((xml = switch_xml_new("directory"))) { - switch_xml_set_attr_d(xml, "type", "freeswitch/xml"); - - if ((sub = switch_xml_add_child_d(xml, "section", off++))) { - switch_xml_set_attr_d(sub, "name", "directory"); - } - - if ((sub = switch_xml_add_child_d(sub, "domain", off++))) { - switch_xml_set_attr_d(sub, "name", dir_domain); - } - - if ((sub = switch_xml_add_child_d(sub, "user", off++))) { - switch_xml_set_attr_d(sub, "id", dir_exten); - } - - } - - search_filter = switch_mprintf(binding->filter, dir_exten); - search_base = switch_mprintf(binding->basedn, dir_domain); - - free(dir_exten); - dir_exten = NULL; - - free(dir_domain); - dir_domain = NULL; - - } else { - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, - "Something bad happened during the query construction phase likely exten(%s) or domain(%s) is null\n", dir_exten, - dir_domain); - goto cleanup; - } - break; - - case XML_LDAP_DIALPLAN: - if ((xml = switch_xml_new("document"))) { - switch_xml_set_attr_d(xml, "type", "freeswitch/xml"); - - if ((sub = switch_xml_add_child_d(xml, "section", off++))) { - switch_xml_set_attr_d(sub, "name", "dialplan"); - } - - sub = switch_xml_add_child_d(xml, "context", off++); - } - - break; - - case XML_LDAP_PHRASE: - case XML_LDAP_LANGUAGE: - break; - } - } else { - goto cleanup; - } - } - - - - if ((ldap->ld = (LDAP *) ldap_init(binding->host, LDAP_PORT)) == NULL) { - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "Unable to connect to ldap server.%s\n", binding->host); - goto cleanup; - } - - if (ldap_set_option(ldap->ld, LDAP_OPT_PROTOCOL_VERSION, &desired_version) != LDAP_OPT_SUCCESS) { - goto cleanup; - } - - ldap_set_option(ldap->ld, LDAP_OPT_X_SASL_SECPROPS, &ldap->sp); - - - - if (binding->binddn) { - if (ldap_bind_s(ldap->ld, binding->binddn, binding->bindpass, auth_method) != LDAP_SUCCESS) { - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "Unable to bind to ldap server %s as %s\n", binding->host, binding->binddn); - goto cleanup; - } - } else { - if (ldap_sasl_interactive_bind_s - (ldap->ld, NULL, binding->defaults->mech, NULL, NULL, (unsigned) (intptr_t) LDAP_SASL_SIMPLE, lutil_sasl_interact, - binding->defaults) != LDAP_SUCCESS) { - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "Unable to sasl_bind to ldap server %s as %s\n", binding->host, - binding->defaults->authcid); - goto cleanup; - } - } - - if (ldap_search_s(ldap->ld, search_base, LDAP_SCOPE_SUBTREE, search_filter, NULL, 0, &ldap->msg) != LDAP_SUCCESS) { - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "Query failed: -b \"%s\" \"%s\"\n", search_base, search_filter); - goto cleanup; - } - - if (ldap_count_entries(ldap->ld, ldap->msg) <= 0) { - goto cleanup; - } - - if (sub && xml_ldap_result(&ldap_connection, binding, &sub, &off, query_type) != SWITCH_STATUS_SUCCESS) { - goto cleanup; - } - - ret = 0; - - cleanup: - if (ldap->msg) { - ldap_msgfree(ldap->msg); - } - - if (ldap->ld) { - ldap_unbind_s(ldap->ld); - } - - switch_safe_free(search_filter); - switch_safe_free(search_base); - - //switch_xml_toxml_buf(xml,buf,0,0,1); - //switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "Providing:\n%s\n", buf); - - if (ret) { - switch_xml_free(xml); - return NULL; - } - - return xml; + return SWITCH_STATUS_FALSE; } - - -static switch_status_t do_config(void) -{ - char *cf = "xml_ldap.conf"; - switch_xml_t cfg, xml, bindings_tag, binding_tag, param; - xml_binding_t *binding = NULL; - int x = 0; - - if (!(xml = switch_xml_open_cfg(cf, &cfg, NULL))) { - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "Open of %s failed\n", cf); - return SWITCH_STATUS_TERM; - } - - if (!(bindings_tag = switch_xml_child(cfg, "bindings"))) { - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "Missing tag!\n"); - goto done; - } - - for (binding_tag = switch_xml_child(bindings_tag, "binding"); binding_tag; binding_tag = binding_tag->next) { - char *bname = (char *) switch_xml_attr_soft(binding_tag, "name"); - - if (!(binding = malloc(sizeof(*binding)))) { - goto done; - } - memset(binding, 0, sizeof(*binding)); - - if (!(binding->defaults = malloc(sizeof(lutilSASLdefaults)))) { - goto done; - } - memset(binding->defaults, 0, sizeof(lutilSASLdefaults)); - - for (param = switch_xml_child(binding_tag, "param"); param; param = param->next) { - - char *var = (char *) switch_xml_attr_soft(param, "name"); - char *val = (char *) switch_xml_attr_soft(param, "value"); - - if (!strcasecmp(var, "filter")) { - binding->bindings = (char *) switch_xml_attr_soft(param, "bindings"); - if (val) { - binding->filter = strdup(val); - } - } else if (!strcasecmp(var, "basedn")) { - binding->basedn = strdup(val); - } else if (!strcasecmp(var, "binddn")) { - binding->binddn = strdup(val); - } else if (!strcasecmp(var, "bindpass")) { - binding->bindpass = strdup(val); - } else if (!strcasecmp(var, "host")) { - binding->host = strdup(val); - } else if (!strcasecmp(var, "mech")) { - binding->defaults->mech = strdup(val); - } else if (!strcasecmp(var, "realm")) { - binding->defaults->realm = strdup(val); - } else if (!strcasecmp(var, "authcid")) { - binding->defaults->authcid = strdup(val); - } else if (!strcasecmp(var, "authzid")) { - binding->defaults->authzid = strdup(val); - } - - } - - if (!binding->basedn || !binding->filter) { - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "You must define \"basedn\", and \"filter\" in mod_xml_ldap.conf.xml\n"); - continue; - } - - - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_NOTICE, "Binding [%s] XML Fetch Function [%s] (%s) [%s]\n", - zstr(bname) ? "N/A" : bname, binding->basedn, binding->filter, binding->bindings ? binding->bindings : "all"); - - switch_xml_bind_search_function(xml_ldap_search, switch_xml_parse_section_string(bname), binding); - - x++; - binding = NULL; - } - - done: - switch_xml_free(xml); - - return SWITCH_STATUS_SUCCESS; -} - - + SWITCH_MODULE_LOAD_FUNCTION(mod_xml_ldap_load) { - switch_api_interface_t *xml_ldap_api_interface; + switch_api_interface_t *xml_ldap_api_interface; - /* connect my internal structure to the blank pointer passed to me */ - *module_interface = switch_loadable_module_create_module_interface(pool, modname); + /* connect my internal structure to the blank pointer passed to me */ + *module_interface = switch_loadable_module_create_module_interface(pool, modname); - SWITCH_ADD_API(xml_ldap_api_interface, "xml_ldap", "XML LDAP", xml_ldap_function, XML_LDAP_SYNTAX); - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_INFO, "XML LDAP module loading...\n"); + SWITCH_ADD_API(xml_ldap_api_interface, "xml_ldap", "XML LDAP", xml_ldap_function, XML_LDAP_SYNTAX); + switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_INFO, "XML LDAP module loading...\n"); - if (do_config() != SWITCH_STATUS_SUCCESS) { - return SWITCH_STATUS_FALSE; + if (do_config() != SWITCH_STATUS_SUCCESS) { + return SWITCH_STATUS_FALSE; } - /* indicate that the module should continue to be loaded */ - return SWITCH_STATUS_SUCCESS; + /* indicate that the module should continue to be loaded */ + return SWITCH_STATUS_SUCCESS; } SWITCH_MODULE_SHUTDOWN_FUNCTION(mod_xml_ldap_shutdown) { + return SWITCH_STATUS_SUCCESS; +} + +static switch_status_t do_config(void) +{ + char *cf = "xml_ldap.conf"; + switch_xml_t cfg, xml, bindings_tag, binding_tag, param, tran; + xml_binding_t *binding = NULL; + xml_ldap_attribute_t *attr_list = NULL; + int x = 0; + + if (!(xml = switch_xml_open_cfg(cf, &cfg, NULL))) { + switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "open of %s failed\n", cf); + return SWITCH_STATUS_TERM; + } + + if (!(bindings_tag = switch_xml_child(cfg, "bindings"))) { + switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "Missing tag!\n"); + goto done; + } + for (binding_tag = switch_xml_child(bindings_tag, "binding"); binding_tag; binding_tag = binding_tag->next) { + char *bname = (char *) switch_xml_attr_soft(binding_tag, "name"); + + if (!(binding = malloc(sizeof(*binding)))) { + goto done; + } + memset(binding, 0, sizeof(*binding)); + binding->attr_list = attr_list; + + for (param = switch_xml_child(binding_tag, "param"); param; param = param->next) { + + char *var = (char *) switch_xml_attr_soft(param, "name"); + char *val = (char *) switch_xml_attr_soft(param, "value"); + + if (!strcasecmp(var, "filter")) { + binding->bindings = (char *) switch_xml_attr_soft(param, "bindings"); + + if (!strncmp(binding->bindings, "configuration", strlen(binding->bindings))) { + switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "setting type XML_LDAP_CONFIG\n"); + binding->bt = XML_LDAP_CONFIG; + } else if (!strncmp(binding->bindings, "directory", strlen(binding->bindings))) { + binding->bt = XML_LDAP_DIRECTORY; + } else if (!strncmp(binding->bindings, "dialplan", strlen(binding->bindings))) { + binding->bt = XML_LDAP_DIALPLAN; + } else if (!strncmp(binding->bindings, "phrases", strlen(binding->bindings))) { + binding->bt = XML_LDAP_PHRASE; + } + + if (val) { + binding->filter = strdup(val); + printf("binding filter %s to %s\n", binding->filter, binding->bindings); + } + } else if (!strncasecmp(var, "basedn", strlen(val))) { + binding->basedn = strdup(val); + } else if (!strncasecmp(var, "binddn", strlen(val))) { + binding->binddn = strdup(val); + } else if (!strncasecmp(var, "bindpass", strlen(val))) { + binding->bindpass = strdup(val); + } else if (!strncasecmp(var, "url", strlen(val))) { + binding->url = strdup(val); + } + } + + if (binding && binding->bt == XML_LDAP_DIRECTORY) { + attr_list = malloc(sizeof(*attr_list)); + attr_list = memset(attr_list, 0, sizeof(*attr_list)); + binding->attr_list = attr_list; + + param = switch_xml_child(binding_tag, "trans"); + for (tran = switch_xml_child(param, "tran"); tran; tran = tran->next) { + char *n = (char *) switch_xml_attr_soft(tran, "name"); + char *m = (char *) switch_xml_attr_soft(tran, "mapfrom"); + switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_NOTICE, " adding map %s => %s\n", m, n); + /* Params */ + if (!strncasecmp("id", n, strlen(n))) { + attr_list->type = LDAP_EXTEN_ID; + attr_list->len = strlen(m); + attr_list->val = strdup(m); + attr_list->next = malloc(sizeof(*attr_list)); + attr_list->next = memset(attr_list->next, 0, sizeof(*attr_list)); + attr_list = attr_list->next; + } else if (!strncasecmp("cidr", n, strlen(n))) { + attr_list->type = LDAP_EXTEN_CIDR; + attr_list->len = strlen(m); + attr_list->val = strdup(m); + attr_list->next = malloc(sizeof(*attr_list)); + attr_list->next = memset(attr_list->next, 0, sizeof(*attr_list)); + attr_list = attr_list->next; + } else if (!strncasecmp("password", n, strlen(n))) { + attr_list->type = LDAP_EXTEN_PASSWORD; + attr_list->len = strlen(m); + attr_list->val = strdup(m); + attr_list->next = malloc(sizeof(*attr_list)); + attr_list->next = memset(attr_list->next, 0, sizeof(*attr_list)); + attr_list = attr_list->next; + } else if (!strncasecmp("vm-enabled", n, strlen(n))) { + attr_list->type = LDAP_EXTEN_VM_ENABLED; + attr_list->len = strlen(m); + attr_list->val = strdup(m); + attr_list->next = malloc(sizeof(*attr_list)); + attr_list->next = memset(attr_list->next, 0, sizeof(*attr_list)); + attr_list = attr_list->next; + } else if (!strncasecmp("vm-password", n, strlen(n))) { + attr_list->type = LDAP_EXTEN_VM_PASSWORD; + attr_list->len = strlen(m); + attr_list->val = strdup(m); + attr_list->next = malloc(sizeof(*attr_list)); + attr_list->next = memset(attr_list->next, 0, sizeof(*attr_list)); + attr_list = attr_list->next; + } else if (!strncasecmp("vm-mailfrom", n, strlen(n))) { + attr_list->type = LDAP_EXTEN_VM_MAILFROM; + attr_list->len = strlen(m); + attr_list->val = strdup(m); + attr_list->next = malloc(sizeof(*attr_list)); + attr_list->next = memset(attr_list->next, 0, sizeof(*attr_list)); + attr_list = attr_list->next; + } else if (!strncasecmp("vm-mailto", n, strlen(n))) { + attr_list->type = LDAP_EXTEN_VM_MAILTO; + attr_list->len = strlen(m); + attr_list->val = strdup(m); + attr_list->next = malloc(sizeof(*attr_list)); + attr_list->next = memset(attr_list->next, 0, sizeof(*attr_list)); + attr_list = attr_list->next; + } else if (!strncasecmp("vm-email-all-messages", n, strlen(n))) { + attr_list->type = LDAP_EXTEN_VM_EMAILMSG; + attr_list->len = strlen(m); + attr_list->val = strdup(m); + attr_list->next = malloc(sizeof(*attr_list)); + attr_list->next = memset(attr_list->next, 0, sizeof(*attr_list)); + attr_list = attr_list->next; + } else if (!strncasecmp("vm-notify-email-all-messages", n, strlen(n))) { + attr_list->type = LDAP_EXTEN_VM_NOTEMAILMSG; + attr_list->len = strlen(m); + attr_list->val = strdup(m); + attr_list->next = malloc(sizeof(*attr_list)); + attr_list->next = memset(attr_list->next, 0, sizeof(*attr_list)); + attr_list = attr_list->next; + } else if (!strncasecmp("vm-attach-file", n, strlen(n))) { + attr_list->type = LDAP_EXTEN_VM_ATTACHFILE; + attr_list->len = strlen(m); + attr_list->val = strdup(m); + attr_list->next = malloc(sizeof(*attr_list)); + attr_list->next = memset(attr_list->next, 0, sizeof(*attr_list)); + attr_list = attr_list->next; + /* Variables */ + } else if (!strncasecmp("user_context", n, strlen(n))) { + attr_list->type = LDAP_EXTEN_USER_CONTEXT; + attr_list->len = strlen(m); + attr_list->val = strdup(m); + attr_list->next = malloc(sizeof(*attr_list)); + attr_list->next = memset(attr_list->next, 0, sizeof(*attr_list)); + attr_list = attr_list->next; + } else if (!strncasecmp("effective_caller_id_name", n, strlen(n))) { + attr_list->type = LDAP_EXTEN_EFF_CLIDNAME; + attr_list->len = strlen(m); + attr_list->val = strdup(m); + attr_list->next = malloc(sizeof(*attr_list)); + attr_list->next = memset(attr_list->next, 0, sizeof(*attr_list)); + attr_list = attr_list->next; + } else if (!strncasecmp("effective_caller_id_number", n, strlen(n))) { + attr_list->type = LDAP_EXTEN_EFF_CLIDNUM; + attr_list->len = strlen(m); + attr_list->val = strdup(m); + attr_list->next = malloc(sizeof(*attr_list)); + attr_list->next = memset(attr_list->next, 0, sizeof(*attr_list)); + attr_list = attr_list->next; + } else if (!strncasecmp("accountcode", n, strlen(n))) { + attr_list->type = LDAP_EXTEN_ACCOUNTCODE; + attr_list->len = strlen(m); + attr_list->val = strdup(m); + attr_list->next = malloc(sizeof(*attr_list)); + attr_list->next = memset(attr_list->next, 0, sizeof(*attr_list)); + attr_list = attr_list->next; + } else if (!strncasecmp("ruleset", n, strlen(n))) { + attr_list->type = LDAP_EXTEN_RULESET; + attr_list->len = strlen(m); + attr_list->val = strdup(m); + attr_list->next = malloc(sizeof(*attr_list)); + attr_list->next = memset(attr_list->next, 0, sizeof(*attr_list)); + attr_list = attr_list->next; + } + } + attr_list->next = NULL; + } + if (!binding->basedn || !binding->filter || !binding->url) { + switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "You must define \"basedn\", and \"filter\" in mod_xml_ldap.conf.xml\n"); + continue; + } + + switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_NOTICE, "Binding [%s] XML Fetch Function [%s] (%s) [%s]\n", + zstr(bname) ? "N/A" : bname, binding->basedn, binding->filter, binding->bindings ? binding->bindings : "all"); + + switch_xml_bind_search_function(xml_ldap_search, switch_xml_parse_section_string(bname), binding); + + x++; + binding = NULL; + } + + done: + switch_xml_free(xml); + return SWITCH_STATUS_SUCCESS; } + +static switch_status_t trydir(switch_xml_t *pxml, int *xoff, LDAP * ld, char *dir_domain, char *dir_exten, xml_binding_t *binding) +{ + switch_status_t ret = SWITCH_STATUS_FALSE; + int off = *xoff; + char *key = NULL; + char *basedn = NULL, *filter = NULL; + struct berval **val = NULL; + BerElement *ber = NULL; + switch_xml_t xml = *pxml, params = NULL, param = NULL, vars = NULL, cur = NULL; + LDAPMessage *msg, *entry; + xml_ldap_attribute_t *attr = NULL; + static char *fsattr[] = + { "id", "cidr", "password", "vm-enabled", "vm-password", "vm-mailfrom", "vm-mailto", + "vm-email-all-messages", "vm-notify-email-all-messages", "vm-attach-file", + "user_context", "effective_caller_id_name", "effective_caller_id_number", + "accountcode", "ruleset", NULL }; + + basedn = switch_mprintf(binding->basedn, dir_domain); + filter = switch_mprintf(binding->filter, dir_exten); + + switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_NOTICE, "searching in basedn %s with filter %s\n", basedn, filter); + + if ((ldap_search_s(ld, basedn, LDAP_SCOPE_SUB, filter, NULL, 0, &msg) != LDAP_SUCCESS)) + goto cleanup; + + if (ldap_count_entries(ld, msg) > 0) { + ret = SWITCH_STATUS_SUCCESS; + xml = switch_xml_add_child_d(xml, "section", off++); + switch_xml_set_attr_d(xml, "name", "directory"); + + xml = switch_xml_add_child_d(xml, "domain", off++); + switch_xml_set_attr_d(xml, "name", dir_domain); + + params = switch_xml_add_child_d(xml, "params", off++); + param = switch_xml_add_child_d(params, "param", off++); + switch_xml_set_attr_d(param, "name", "dial-string"); + switch_xml_set_attr_d(param, "value", "{^^:sip_invite_domain=${dialed_domain}:presence_id=${dialed_user}@${dialed_domain}}${sofia_contact(*/${dialed_user}@${dialed_domain})}"); + + xml = switch_xml_add_child_d(xml, "user", off++); + + params = switch_xml_add_child_d(xml, "params", off++); + vars = switch_xml_add_child_d(xml, "variables", off++); + + for (entry = ldap_first_entry(ld, msg); entry != NULL; entry = ldap_next_entry(ld, entry)) { + switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_NOTICE, "entry searched by filter %s\n", filter); + + for (key = ldap_first_attribute(ld, entry, &ber); key != NULL; key = ldap_next_attribute(ld, entry, ber)) { + + for (attr = binding->attr_list; attr; attr = attr->next) { + if (strlen(key) == attr->len) { + if (!strncasecmp(attr->val, key, strlen(key))) { + val = ldap_get_values_len(ld, entry, key); + if (val != NULL) { + if (ldap_count_values_len(val) > 0 && val[0] != NULL && val[0]->bv_val != NULL) { + switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_NOTICE, " attribute %s => %s\n", fsattr[attr->type], val[0]->bv_val); + if (attr->type < 2) { + switch_xml_set_attr_d(xml, fsattr[attr->type], val[0]->bv_val); + } else if (attr->type < 10) { + cur = switch_xml_add_child_d(params, "param", 0); + switch_xml_set_attr_d(cur, "name", fsattr[attr->type]); + switch_xml_set_attr_d(cur, "value", val[0]->bv_val); + } else { + cur = switch_xml_add_child_d(vars, "variable", 0); + switch_xml_set_attr_d(cur, "name", fsattr[attr->type]); + switch_xml_set_attr_d(cur, "value", val[0]->bv_val); + } + } + ldap_value_free_len(val); + } + continue; + } + } + } + ldap_memfree(key); + } + ber_free(ber, 0); + } + + ldap_msgfree(entry); + ldap_msgfree(msg); + } else { + ret = SWITCH_STATUS_FALSE; + } + + cleanup: + switch_safe_free(filter); + switch_safe_free(basedn) + switch_safe_free(dir_exten); + switch_safe_free(dir_domain); + + return ret; +} + +static switch_status_t trysearch(switch_xml_t *pxml, int *xoff, LDAP * ld, char *basedn, char *filter) +{ + switch_status_t ret = SWITCH_STATUS_FALSE; + int off = *xoff; + char *key = NULL; + char *dn = NULL; + char **val = NULL; + BerElement *ber = NULL; + switch_xml_t xml = *pxml; + LDAPMessage *msg, *entry; + + switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "trying search in base %s with filter %s\n", basedn, filter); + + if ((ldap_search_s(ld, basedn, LDAP_SCOPE_ONE, filter, NULL, 0, &msg) != LDAP_SUCCESS)) + goto cleanup; + + if (ldap_count_entries(ld, msg) > 0) { + ret = SWITCH_STATUS_SUCCESS; + for (entry = ldap_first_entry(ld, msg); entry != NULL; entry = ldap_next_entry(ld, entry)) { + + val = ldap_get_values(ld, entry, "fstag"); + xml = switch_xml_add_child_d(xml, val[0], off); + ldap_value_free(val); + + for (key = ldap_first_attribute(ld, entry, &ber); key != NULL; key = ldap_next_attribute(ld, entry, ber)) { + + if (!strncasecmp(key, "fstag", strlen(key)) || !strncasecmp(key, "objectclass", strlen(key))) { + ldap_memfree(key); + continue; + } + + val = ldap_get_values(ld, entry, key); + switch_xml_set_attr_d(xml, key, val[0]); + + ldap_memfree(key); + ldap_value_free(val); + } + ber_free(ber, 0); + + dn = ldap_get_dn(ld, entry); + rec(&xml, &off, ld, dn); + + *xoff = 1; + } + + ldap_msgfree(entry); + ldap_msgfree(msg); + } + + cleanup: + switch_safe_free(basedn); + switch_safe_free(filter); + switch_safe_free(key); + + return ret; +} + +void rec(switch_xml_t *pxml, int *xoff, LDAP * ld, char *dn) +{ + int off = *xoff; + char *key; + char **val; + + switch_xml_t xml = *pxml, new; + + LDAPMessage *msg, *entry; + BerElement *ber; + + ldap_search_s(ld, dn, LDAP_SCOPE_ONE, NULL, NULL, 0, &msg); + switch_safe_free(dn); + + if (ldap_count_entries(ld, msg) > 0) { + + for (entry = ldap_first_entry(ld, msg); entry != NULL; entry = ldap_next_entry(ld, entry)) { + + val = ldap_get_values(ld, entry, "fstag"); + new = switch_xml_add_child_d(xml, val[0], off); + ldap_value_free(val); + + for (key = ldap_first_attribute(ld, entry, &ber); key != NULL; key = ldap_next_attribute(ld, entry, ber)) { + + if (!strncasecmp("fstag", key, 5) || !strncasecmp("objectclass", key, 10)) { + ldap_memfree(key); + continue; + } + + val = ldap_get_values(ld, entry, key); + switch_xml_set_attr_d(new, key, val[0]); + ldap_memfree(key); + ldap_value_free(val); + } + ber_free(ber, 0); + rec(&new, xoff, ld, ldap_get_dn(ld, entry)); + } + ldap_msgfree(entry); + + } + + ldap_msgfree(msg); +} + +static switch_xml_t xml_ldap_search(const char *section, const char *tag_name, const char *key_name, const char *key_value, switch_event_t *params, + void *user_data) +{ + + xml_binding_t *binding = (xml_binding_t *) user_data; + switch_event_header_t *hi; + switch_status_t ret = SWITCH_STATUS_FALSE; + + int desired_version = LDAP_VERSION3; + int auth_method = LDAP_AUTH_SIMPLE; + + char *basedn = NULL, *filter = NULL; + char *dir_domain = NULL, *dir_exten = NULL; + + LDAP *ld; + switch_xml_t xml = NULL; + + int xoff = 0; + + char *buf; + buf = malloc(4096); + + xml = switch_xml_new("document"); + switch_xml_set_attr_d(xml, "type", "freeswitch/xml"); + + if (params) { + if ((hi = params->headers)) { + for (; hi; hi = hi->next) { + switch (binding->bt) { + case XML_LDAP_CONFIG: + break; + + case XML_LDAP_DIRECTORY: + switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, "from cb got %s=%s\n", hi->name, hi->value); + if (!strncmp(hi->name, "user", strlen(hi->name))) { + dir_exten = strdup(hi->value); + } else if (!strncmp(hi->name, "domain", strlen(hi->name))) { + dir_domain = strdup(hi->value); + } + break; + + case XML_LDAP_DIALPLAN: + case XML_LDAP_PHRASE: + break; + } + } + } + } + if ((ldap_initialize(&ld, binding->url)) != LDAP_SUCCESS) + goto cleanup; + if ((ldap_set_option(ld, LDAP_OPT_PROTOCOL_VERSION, &desired_version)) != LDAP_SUCCESS) + goto cleanup; + if ((ldap_bind_s(ld, binding->binddn, binding->bindpass, auth_method)) != LDAP_SUCCESS) + goto cleanup; + + switch (binding->bt) { + case XML_LDAP_CONFIG: + xml = switch_xml_add_child_d(xml, "section", xoff++); + switch_xml_set_attr_d(xml, "name", "configuration"); + filter = switch_mprintf(binding->filter, key_name, key_value); + basedn = switch_mprintf(binding->basedn, tag_name); + ret = trysearch(&xml, &xoff, ld, basedn, filter); + break; + + case XML_LDAP_DIRECTORY: + ret = trydir(&xml, &xoff, ld, dir_domain, dir_exten, binding); + break; + + case XML_LDAP_DIALPLAN: + break; + + case XML_LDAP_PHRASE: + break; + } + + + cleanup: + ldap_unbind_s(ld); + + switch_xml_toxml_buf(xml, buf, 0, 0, 1); + switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG,"XML providing:\n%s\n", buf); + switch_safe_free(buf); + + if (ret != SWITCH_STATUS_SUCCESS) { + switch_xml_free(xml); + return NULL; + } + + return xml; +} + + /* For Emacs: * Local Variables: * mode:c diff --git a/src/mod/xml_int/mod_xml_ldap/mod_xml_ldapv2.c b/src/mod/xml_int/mod_xml_ldap/mod_xml_ldapv2.c deleted file mode 100644 index 519ed8e195..0000000000 --- a/src/mod/xml_int/mod_xml_ldap/mod_xml_ldapv2.c +++ /dev/null @@ -1,565 +0,0 @@ -#include -#include -#include -#include -#include - -#define PCACHE_TTL 300 -#define NCACHE_TTL 900 - -typedef struct xml_ldap_attribute xml_ldap_attribute_t; - - -typedef enum { - XML_LDAP_CONFIG = 0, - XML_LDAP_DIRECTORY, - XML_LDAP_DIALPLAN, - XML_LDAP_PHRASE -} xml_ldap_query_type_t; - - -typedef struct xml_binding { - char *bindings; - xml_ldap_query_type_t bt; - char *url; - char *basedn; - char *binddn; - char *bindpass; - char *filter; - xml_ldap_attribute_t *attr_list; -} xml_binding_t; - -typedef enum exten_types { - LDAP_EXTEN_ID = 0, - LDAP_EXTEN_VM_MAILBOX, - LDAP_EXTEN_PASSWORD, - LDAP_EXTEN_VM_PASSWORD, - LDAP_EXTEN_VM_EMAILADDR, - LDAP_EXTEN_VM_EMAILMSG, - LDAP_EXTEN_VM_DELETE, - LDAP_EXTEN_VM_ATTACHAUDIO, - LDAP_EXTEN_NAME, - LDAP_EXTEN_LABEL, - LDAP_EXTEN_AREACODE, - LDAP_EXTEN_CID_EXTNAME, - LDAP_EXTEN_CID_EXTNUM, - LDAP_EXTEN_INTNAME, - LDAP_EXTEN_INTNUM, - LDAP_EXTEN_RECORD_CALLS, - LDAP_EXTEN_ACTIVE, - LDAP_EXTEN_CFWD_REWRITECID, - LDAP_EXTEN_CFWD_ACTIVE, - LDAP_EXTEN_CFWD_DEST, - LDAP_EXTEN_CFWD_BUSYACTIVE, - LDAP_EXTEN_CFWD_BUSYDEST, - LDAP_EXTEN_NOANSWERACTIVE, - LDAP_EXTEN_NOANSWERDEST, - LDAP_EXTEN_NOANSWERSECONDS, - LDAP_EXTEN_PROGRESSAUDIO, - LDAP_EXTEN_ALLOW_OUTOBUND, - LDAP_EXTEN_ALLOW_XFER, - LDAP_EXTEN_HOTLINE_ACTIVE, - LDAP_EXTEN_HOTLINE_DEST, - LDAP_EXTEN_CLASSOFSERVICE -} exten_type_t; - -struct xml_ldap_attribute { - exten_type_t type; - uint64_t len; - char *val; - xml_ldap_attribute_t *next; -}; - - -SWITCH_MODULE_LOAD_FUNCTION(mod_xml_ldap_load); -SWITCH_MODULE_SHUTDOWN_FUNCTION(mod_xml_ldap_shutdown); -SWITCH_MODULE_DEFINITION(mod_xml_ldap, mod_xml_ldap_load, mod_xml_ldap_shutdown, NULL); - - -static switch_xml_t xml_ldap_search(const char *section, const char *tag_name, const char *key_name, const char *key_value, switch_event_t *params, - void *user_data); - -static switch_status_t trydir(switch_xml_t *, int *, LDAP *, char *, char *, xml_binding_t *); -static switch_status_t do_config(void); -static switch_status_t trysearch(switch_xml_t *pxml, int *xoff, LDAP * ld, char *basedn, char *filter); -void rec(switch_xml_t *, int *, LDAP * ld, char *); - -#define XML_LDAP_SYNTAX "" - -SWITCH_STANDARD_API(xml_ldap_function) -{ - return SWITCH_STATUS_FALSE; -} - -SWITCH_MODULE_LOAD_FUNCTION(mod_xml_ldap_load) -{ - switch_api_interface_t *xml_ldap_api_interface; - - /* connect my internal structure to the blank pointer passed to me */ - *module_interface = switch_loadable_module_create_module_interface(pool, modname); - - SWITCH_ADD_API(xml_ldap_api_interface, "xml_ldap", "XML LDAP", xml_ldap_function, XML_LDAP_SYNTAX); - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_INFO, "XML LDAP module loading...\n"); - - if (do_config() != SWITCH_STATUS_SUCCESS) { - return SWITCH_STATUS_FALSE; - } - - - /* indicate that the module should continue to be loaded */ - return SWITCH_STATUS_SUCCESS; -} - -SWITCH_MODULE_SHUTDOWN_FUNCTION(mod_xml_ldap_shutdown) -{ - return SWITCH_STATUS_SUCCESS; -} - -static switch_status_t do_config(void) -{ - char *cf = "xml_ldap.conf"; - switch_xml_t cfg, xml, bindings_tag, binding_tag, param, tran; - xml_binding_t *binding = NULL; - xml_ldap_attribute_t *attr_list = NULL; - int x = 0; - - if (!(xml = switch_xml_open_cfg(cf, &cfg, NULL))) { - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "open of %s failed\n", cf); - return SWITCH_STATUS_TERM; - } - - if (!(bindings_tag = switch_xml_child(cfg, "bindings"))) { - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "Missing tag!\n"); - goto done; - } - - for (binding_tag = switch_xml_child(bindings_tag, "binding"); binding_tag; binding_tag = binding_tag->next) { - char *bname = (char *) switch_xml_attr_soft(binding_tag, "name"); - - if (!(binding = malloc(sizeof(*binding)))) { - goto done; - } - memset(binding, 0, sizeof(*binding)); - binding->attr_list = attr_list; - - for (param = switch_xml_child(binding_tag, "param"); param; param = param->next) { - - char *var = (char *) switch_xml_attr_soft(param, "name"); - char *val = (char *) switch_xml_attr_soft(param, "value"); - - if (!strcasecmp(var, "filter")) { - binding->bindings = (char *) switch_xml_attr_soft(param, "bindings"); - - if (!strncmp(binding->bindings, "configuration", strlen(binding->bindings))) { - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "setting type XML_LDAP_CONFIG\n"); - binding->bt = XML_LDAP_CONFIG; - } else if (!strncmp(binding->bindings, "directory", strlen(binding->bindings))) { - binding->bt = XML_LDAP_DIRECTORY; - } else if (!strncmp(binding->bindings, "dialplain", strlen(binding->bindings))) { - binding->bt = XML_LDAP_DIALPLAN; - } else if (!strncmp(binding->bindings, "phrases", strlen(binding->bindings))) { - binding->bt = XML_LDAP_PHRASE; - } - - if (val) { - binding->filter = strdup(val); - printf("binding filter %s to %s\n", binding->filter, binding->bindings); - } - } else if (!strncasecmp(var, "basedn", strlen(val))) { - binding->basedn = strdup(val); - } else if (!strncasecmp(var, "binddn", strlen(val))) { - binding->binddn = strdup(val); - } else if (!strncasecmp(var, "bindpass", strlen(val))) { - binding->bindpass = strdup(val); - } else if (!strncasecmp(var, "url", strlen(val))) { - binding->url = strdup(val); - } - - } - - if (binding && binding->bt == XML_LDAP_DIRECTORY) { - attr_list = malloc(sizeof(*attr_list)); - attr_list = memset(attr_list, 0, sizeof(*attr_list)); - binding->attr_list = attr_list; - - param = switch_xml_child(binding_tag, "trans"); - for (tran = switch_xml_child(param, "tran"); tran; tran = tran->next) { - char *n = (char *) switch_xml_attr_soft(tran, "name"); - char *m = (char *) switch_xml_attr_soft(tran, "mapfrom"); - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_NOTICE, " adding map %s => %s\n", m, n); - if (!strncasecmp("id", n, strlen(n))) { - attr_list->type = LDAP_EXTEN_ID; - attr_list->len = strlen(m); - attr_list->val = strdup(m); - attr_list->next = malloc(sizeof(*attr_list)); - attr_list->next = memset(attr_list->next, 0, sizeof(*attr_list)); - attr_list = attr_list->next; - } else if (!strncasecmp("mailbox", n, strlen(n))) { - attr_list->type = LDAP_EXTEN_VM_MAILBOX; - attr_list->len = strlen(m); - attr_list->val = strdup(m); - attr_list->next = malloc(sizeof(*attr_list)); - attr_list->next = memset(attr_list->next, 0, sizeof(*attr_list)); - attr_list = attr_list->next; - } else if (!strncasecmp("password", n, strlen(n))) { - attr_list->type = LDAP_EXTEN_PASSWORD; - attr_list->len = strlen(m); - attr_list->val = strdup(m); - attr_list->next = malloc(sizeof(*attr_list)); - attr_list->next = memset(attr_list->next, 0, sizeof(*attr_list)); - attr_list = attr_list->next; - } else if (!strncasecmp("vm-password", n, strlen(n))) { - attr_list->type = LDAP_EXTEN_VM_PASSWORD; - attr_list->len = strlen(m); - attr_list->val = strdup(m); - attr_list->next = malloc(sizeof(*attr_list)); - attr_list->next = memset(attr_list->next, 0, sizeof(*attr_list)); - attr_list = attr_list->next; - } else if (!strncasecmp("email-addr", n, strlen(n))) { - attr_list->type = LDAP_EXTEN_VM_EMAILADDR; - attr_list->len = strlen(m); - attr_list->val = strdup(m); - attr_list->next = malloc(sizeof(*attr_list)); - attr_list->next = memset(attr_list->next, 0, sizeof(*attr_list)); - attr_list = attr_list->next; - } else if (!strncasecmp("vm-email-all-messages", n, strlen(n))) { - attr_list->type = LDAP_EXTEN_VM_EMAILMSG; - attr_list->len = strlen(m); - attr_list->val = strdup(m); - attr_list->next = malloc(sizeof(*attr_list)); - attr_list->next = memset(attr_list->next, 0, sizeof(*attr_list)); - attr_list = attr_list->next; - } else if (!strncasecmp("vm-delete-file", n, strlen(n))) { - attr_list->type = LDAP_EXTEN_VM_DELETE; - attr_list->len = strlen(m); - attr_list->val = strdup(m); - attr_list->next = malloc(sizeof(*attr_list)); - attr_list->next = memset(attr_list->next, 0, sizeof(*attr_list)); - attr_list = attr_list->next; - } else if (!strncasecmp("vm-attach-file", n, strlen(n))) { - attr_list->type = LDAP_EXTEN_VM_ATTACHAUDIO; - attr_list->len = strlen(m); - attr_list->val = strdup(m); - attr_list->next = malloc(sizeof(*attr_list)); - attr_list->next = memset(attr_list->next, 0, sizeof(*attr_list)); - attr_list = attr_list->next; - } - - } - attr_list->next = NULL; - } - - - if (!binding->basedn || !binding->filter || !binding->url) { - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "You must define \"basedn\", and \"filter\" in mod_xml_ldap.conf.xml\n"); - continue; - } - - - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_NOTICE, "Binding [%s] XML Fetch Function [%s] (%s) [%s]\n", - zstr(bname) ? "N/A" : bname, binding->basedn, binding->filter, binding->bindings ? binding->bindings : "all"); - - switch_xml_bind_search_function(xml_ldap_search, switch_xml_parse_section_string(bname), binding); - - x++; - binding = NULL; - } - - done: - switch_xml_free(xml); - - return SWITCH_STATUS_SUCCESS; -} - -static switch_status_t trydir(switch_xml_t *pxml, int *xoff, LDAP * ld, char *dir_domain, char *dir_exten, xml_binding_t *binding) -{ - switch_status_t ret = SWITCH_STATUS_FALSE; - int off = *xoff; - char *key = NULL; - char *basedn = NULL, *filter = NULL; - char **val = NULL; - BerElement *ber = NULL; - switch_xml_t xml = *pxml, params = NULL, vars = NULL, cur = NULL; - LDAPMessage *msg, *entry; - static char *fsattr[] = - { "id", "mailbox", "password", "vm-password", "email-addr", "vm-email-all-messages", "vm-delete-file", "vm-attach-file", NULL }; - - basedn = switch_mprintf(binding->basedn, dir_domain); - filter = switch_mprintf(binding->filter, dir_exten); - xml_ldap_attribute_t *attr = NULL; - - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_NOTICE, "searching in basedn %s with filter %s\n", basedn, filter); - - if ((ldap_search_s(ld, basedn, LDAP_SCOPE_SUB, filter, NULL, 0, &msg) != LDAP_SUCCESS)) - goto cleanup; - - if (ldap_count_entries(ld, msg) > 0) { - ret = SWITCH_STATUS_SUCCESS; - xml = switch_xml_add_child_d(xml, "section", off++); - switch_xml_set_attr_d(xml, "name", "directory"); - - xml = switch_xml_add_child_d(xml, "domain", off++); - switch_xml_set_attr_d(xml, "name", dir_domain); - - xml = switch_xml_add_child_d(xml, "user", off++); - - vars = switch_xml_add_child_d(xml, "variables", off++); - params = switch_xml_add_child_d(xml, "params", off++); - - - for (entry = ldap_first_entry(ld, msg); entry != NULL; entry = ldap_next_entry(ld, entry)) { - - - for (key = ldap_first_attribute(ld, entry, &ber); key != NULL; key = ldap_next_attribute(ld, entry, ber)) { - - for (attr = binding->attr_list; attr; attr = attr->next) { - if (strlen(key) == attr->len) { - if (!strncasecmp(attr->val, key, strlen(key))) { - val = ldap_get_values(ld, entry, key); - if (ldap_count_values(val) == 1) { - if (attr->type < 2) { - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_NOTICE, "setting %s = %s ", fsattr[attr->type], val[0]); - switch_xml_set_attr_d(xml, fsattr[attr->type], val[0]); - } else if (attr->type < 8) { - cur = switch_xml_add_child_d(params, "param", 0); - switch_xml_set_attr_d(cur, fsattr[attr->type], val[0]); - } else { - cur = switch_xml_add_child_d(vars, "variable", 0); - switch_xml_set_attr_d(cur, fsattr[attr->type], val[0]); - } - } else { - /* multi val attrs */ - } - ldap_value_free(val); - continue; - } - } - } - ldap_memfree(key); - } - ber_free(ber, 0); - } - - ldap_msgfree(entry); - ldap_msgfree(msg); - } else { - ret = SWITCH_STATUS_FALSE; - } - - cleanup: - switch_safe_free(filter); - switch_safe_free(basedn) - switch_safe_free(dir_exten); - switch_safe_free(dir_domain); - - return ret; -} - - - - -static switch_status_t trysearch(switch_xml_t *pxml, int *xoff, LDAP * ld, char *basedn, char *filter) -{ - switch_status_t ret; - int off = *xoff; - char *key = NULL; - char *dn = NULL; - char **val = NULL; - BerElement *ber = NULL; - switch_xml_t xml = *pxml; - LDAPMessage *msg, *entry; - - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "trying search in base %s with filter %s\n", basedn, filter); - - if ((ldap_search_s(ld, basedn, LDAP_SCOPE_ONE, filter, NULL, 0, &msg) != LDAP_SUCCESS)) - goto cleanup; - - - if (ldap_count_entries(ld, msg) > 0) { - ret = SWITCH_STATUS_SUCCESS; - for (entry = ldap_first_entry(ld, msg); entry != NULL; entry = ldap_next_entry(ld, entry)) { - - val = ldap_get_values(ld, entry, "fstag"); - xml = switch_xml_add_child_d(xml, val[0], off); - ldap_value_free(val); - - for (key = ldap_first_attribute(ld, entry, &ber); key != NULL; key = ldap_next_attribute(ld, entry, ber)) { - - if (!strncasecmp(key, "fstag", strlen(key)) || !strncasecmp(key, "objectclass", strlen(key))) { - ldap_memfree(key); - continue; - } - - val = ldap_get_values(ld, entry, key); - switch_xml_set_attr_d(xml, key, val[0]); - - ldap_memfree(key); - ldap_value_free(val); - - } - ber_free(ber, 0); - - dn = ldap_get_dn(ld, entry); - rec(&xml, &off, ld, dn); - - *xoff = 1; - } - - ldap_msgfree(entry); - ldap_msgfree(msg); - } else { - ret = SWITCH_STATUS_FALSE; - } - - cleanup: - switch_safe_free(basedn); - switch_safe_free(filter); - switch_safe_free(key); - - return ret; - -} - - - - -void rec(switch_xml_t *pxml, int *xoff, LDAP * ld, char *dn) -{ - int off = *xoff; - char *key; - char **val; - - switch_xml_t xml = *pxml, new; - - LDAPMessage *msg, *entry; - BerElement *ber; - - ldap_search_s(ld, dn, LDAP_SCOPE_ONE, NULL, NULL, 0, &msg); - switch_safe_free(dn); - - if (ldap_count_entries(ld, msg) > 0) { - - for (entry = ldap_first_entry(ld, msg); entry != NULL; entry = ldap_next_entry(ld, entry)) { - - val = ldap_get_values(ld, entry, "fstag"); - new = switch_xml_add_child_d(xml, val[0], off); - ldap_value_free(val); - - for (key = ldap_first_attribute(ld, entry, &ber); key != NULL; key = ldap_next_attribute(ld, entry, ber)) { - - if (!strncasecmp("fstag", key, 5) || !strncasecmp("objectclass", key, 10)) { - ldap_memfree(key); - continue; - } - - val = ldap_get_values(ld, entry, key); - switch_xml_set_attr_d(new, key, val[0]); - ldap_memfree(key); - ldap_value_free(val); - } - ber_free(ber, 0); - rec(&new, xoff, ld, ldap_get_dn(ld, entry)); - } - - ldap_msgfree(entry); - - } - ldap_msgfree(msg); -} - - -static switch_xml_t xml_ldap_search(const char *section, const char *tag_name, const char *key_name, const char *key_value, switch_event_t *params, - void *user_data) -{ - - xml_binding_t *binding = (xml_binding_t *) user_data; - switch_event_header_t *hi; - switch_status_t ret = SWITCH_STATUS_FALSE; - - int desired_version = LDAP_VERSION3; - int auth_method = LDAP_AUTH_SIMPLE; - - char *basedn = NULL, *filter = NULL; - char *dir_domain = NULL, *dir_exten = NULL; - - char *buf; - buf = malloc(4096); - - LDAP *ld; - switch_xml_t xml = NULL; - - int xoff = 0; - - xml = switch_xml_new("document"); - switch_xml_set_attr_d(xml, "type", "freeswitch/xml"); - - if (params) { - if ((hi = params->headers)) { - for (; hi; hi = hi->next) { - switch (binding->bt) { - case XML_LDAP_CONFIG: - break; - - case XML_LDAP_DIRECTORY: - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "from cb got %s=%s\n", hi->name, hi->value); - if (!strncmp(hi->name, "user", strlen(hi->name))) { - dir_exten = strdup(hi->value); - } else if (!strncmp(hi->name, "domain", strlen(hi->name))) { - dir_domain = strdup(hi->value); - } - break; - - case XML_LDAP_DIALPLAN: - case XML_LDAP_PHRASE: - break; - } - } - } - } - - - - if ((ldap_initialize(&ld, binding->url)) != LDAP_SUCCESS) - goto cleanup; - if ((ldap_set_option(ld, LDAP_OPT_PROTOCOL_VERSION, &desired_version)) != LDAP_SUCCESS) - goto cleanup; - if ((ldap_bind_s(ld, binding->binddn, binding->bindpass, auth_method)) != LDAP_SUCCESS) - goto cleanup; - - switch (binding->bt) { - case XML_LDAP_CONFIG: - xml = switch_xml_add_child_d(xml, "section", xoff++); - switch_xml_set_attr_d(xml, "name", "configuration"); - filter = switch_mprintf(binding->filter, key_name, key_value); - basedn = switch_mprintf(binding->basedn, tag_name); - ret = trysearch(&xml, &xoff, ld, basedn, filter); - break; - - case XML_LDAP_DIRECTORY: - ret = trydir(&xml, &xoff, ld, dir_domain, dir_exten, binding); - break; - - case XML_LDAP_DIALPLAN: - break; - - case XML_LDAP_PHRASE: - break; - } - - - - - cleanup: - ldap_unbind_s(ld); - - switch_xml_toxml_buf(xml, buf, 0, 0, 1); - printf("providing:\n%s\n", buf); - switch_safe_free(buf); - - if (ret != SWITCH_STATUS_SUCCESS) { - switch_xml_free(xml); - return NULL; - } - - return xml; -}