r23792: convert Samba4 to GPLv3
[garming/samba-autobuild/.git] / source4 / ldap_server / ldap_backend.c
index 273c70392483121c78a9f1e1b29d22f32dd61ee5..be11a47f87ea62ef50736e25d368930259b5e214 100644 (file)
@@ -5,7 +5,7 @@
    
    This program is free software; you can redistribute it and/or modify
    it under the terms of the GNU General Public License as published by
-   the Free Software Foundation; either version 2 of the License, or
+   the Free Software Foundation; either version 3 of the License, or
    (at your option) any later version.
    
    This program is distributed in the hope that it will be useful,
    GNU General Public License for more details.
    
    You should have received a copy of the GNU General Public License
-   along with this program; if not, write to the Free Software
-   Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
+   along with this program.  If not, see <http://www.gnu.org/licenses/>.
 */
 
 #include "includes.h"
 #include "ldap_server/ldap_server.h"
-#include "dlinklist.h"
+#include "lib/util/dlinklist.h"
 #include "libcli/ldap/ldap.h"
 #include "lib/ldb/include/ldb.h"
 #include "lib/ldb/include/ldb_errors.h"
 #include "lib/db_wrap.h"
+#include "auth/credentials/credentials.h"
+#include "auth/gensec/gensec.h"
 
 #define VALID_DN_SYNTAX(dn,i) do {\
        if (!(dn)) {\
                return NT_STATUS_NO_MEMORY;\
-       } else if ((dn)->comp_num < (i)) {\
+       } else if ( ! ldb_dn_validate(dn)) {\
+               result = LDAP_INVALID_DN_SYNTAX;\
+               errstr = "Invalid DN format";\
+               goto reply;\
+       } else if (ldb_dn_get_comp_num(dn) < (i)) {\
                result = LDAP_INVALID_DN_SYNTAX;\
                errstr = "Invalid DN (" #i " components needed for '" #dn "')";\
                goto reply;\
@@ -54,10 +59,34 @@ NTSTATUS ldapsrv_backend_Init(struct ldapsrv_connection *conn)
        if (conn->ldb == NULL) {
                return NT_STATUS_INTERNAL_DB_CORRUPTION;
        }
-       ldb_set_opaque(conn->ldb, "server_credentials", conn->server_credentials);
 
-       if (conn->global_catalog) {
-               ldb_set_opaque(conn->ldb, "global_catalog", (void *)(-1));
+       if (conn->server_credentials) {
+               char **sasl_mechs = NULL;
+               struct gensec_security_ops **backends = gensec_security_all();
+               enum credentials_use_kerberos use_kerberos
+                       = cli_credentials_get_kerberos_state(conn->server_credentials);
+               struct gensec_security_ops **ops
+                       = gensec_use_kerberos_mechs(conn, backends, use_kerberos);
+               int i, j = 0;
+               for (i = 0; ops && ops[i]; i++) {
+                       if (ops[i]->sasl_name && ops[i]->server_start) {
+                               char *sasl_name = talloc_strdup(conn, ops[i]->sasl_name);
+
+                               if (!sasl_name) {
+                                       return NT_STATUS_NO_MEMORY;
+                               }
+                               sasl_mechs = talloc_realloc(conn, sasl_mechs, char *, j + 2);
+                               if (!sasl_mechs) {
+                                       return NT_STATUS_NO_MEMORY;
+                               }
+                               sasl_mechs[j] = sasl_name;
+                               talloc_steal(sasl_mechs, sasl_name);
+                               sasl_mechs[j+1] = NULL;
+                               j++;
+                       }
+               }
+               talloc_free(ops);
+               ldb_set_opaque(conn->ldb, "supportedSASLMechanims", sasl_mechs);
        }
 
        return NT_STATUS_OK;
@@ -113,65 +142,6 @@ NTSTATUS ldapsrv_unwilling(struct ldapsrv_call *call, int error)
        return NT_STATUS_OK;
 }
 
-static int ldapsrv_SearchCallback(struct ldb_context *ldb, void *context, struct ldb_reply *ares)
-{
-       struct ldb_result *res;
-       int n;
-       
-       if (!context || !ares) {
-               DEBUG(3, ("NULL Context or Ares in ldapsrv_SearchCallback"));
-               return LDB_ERR_OPERATIONS_ERROR;
-       }       
-
-       res = talloc_get_type(context, struct ldb_result);
-
-       if (ares->type == LDB_REPLY_ENTRY) {
-               res->msgs = talloc_realloc(res, res->msgs, struct ldb_message *, res->count + 2);
-               if (! res->msgs) {
-                       goto error;
-               }
-
-               res->msgs[res->count + 1] = NULL;
-
-               res->msgs[res->count] = talloc_steal(res->msgs, ares->message);
-               if (! res->msgs[res->count]) {
-                       goto error;
-               }
-
-               res->count++;
-       }
-
-       if (ares->type == LDB_REPLY_REFERRAL) {
-               if (res->refs) {
-                       for (n = 0; res->refs[n]; n++) /*noop*/ ;
-               } else {
-                       n = 0;
-               }
-
-               res->refs = talloc_realloc(res, res->refs, char *, n + 2);
-               if (! res->refs) {
-                       goto error;
-               }
-
-               res->refs[n] = talloc_steal(res->refs, ares->referral);
-               res->refs[n + 1] = NULL;
-       }
-
-       if (ares->controls) {
-               res->controls = talloc_steal(res, ares->controls);
-               if (! res->controls) {
-                       goto error;
-               }
-       }
-
-       talloc_free(ares);
-       return LDB_SUCCESS;
-
-error:
-       talloc_free(ares);
-       return LDB_ERR_OPERATIONS_ERROR;
-}
-
 static NTSTATUS ldapsrv_SearchRequest(struct ldapsrv_call *call)
 {
        struct ldap_SearchRequest *req = &call->request->r.SearchRequest;
@@ -198,7 +168,7 @@ static NTSTATUS ldapsrv_SearchRequest(struct ldapsrv_call *call)
        local_ctx = talloc_new(call);
        NT_STATUS_HAVE_NO_MEMORY(local_ctx);
 
-       basedn = ldb_dn_explode(local_ctx, req->basedn);
+       basedn = ldb_dn_new(local_ctx, samdb, req->basedn);
        VALID_DN_SYNTAX(basedn, 0);
 
        DEBUG(10, ("SearchRequest: basedn: [%s]\n", req->basedn));
@@ -220,10 +190,14 @@ static NTSTATUS ldapsrv_SearchRequest(struct ldapsrv_call *call)
                        scope = LDB_SCOPE_SUBTREE;
                        success_limit = 0;
                        break;
+               default:
+                       result = LDAP_PROTOCOL_ERROR;
+                       errstr = "Invalid scope";
+                       break;
        }
 
        if (req->num_attributes >= 1) {
-               attrs = talloc_array(samdb, const char *, req->num_attributes+1);
+               attrs = talloc_array(local_ctx, const char *, req->num_attributes+1);
                NT_STATUS_HAVE_NO_MEMORY(attrs);
 
                for (i=0; i < req->num_attributes; i++) {
@@ -250,8 +224,23 @@ static NTSTATUS ldapsrv_SearchRequest(struct ldapsrv_call *call)
 
        lreq->controls = call->request->controls;
 
+       if (call->conn->global_catalog) {
+               struct ldb_control *search_control = ldb_request_get_control(lreq, LDB_CONTROL_SEARCH_OPTIONS_OID);
+               
+               struct ldb_search_options_control *search_options = NULL;
+               if (search_control) {
+                       search_options = talloc_get_type(search_control->data, struct ldb_search_options_control);
+                       search_options->search_options |= LDB_SEARCH_OPTION_PHANTOM_ROOT;
+               } else {
+                       search_options = talloc(lreq, struct ldb_search_options_control);
+                       NT_STATUS_HAVE_NO_MEMORY(search_options);
+                       search_options->search_options = LDB_SEARCH_OPTION_PHANTOM_ROOT;
+                       ldb_request_add_control(lreq, LDB_CONTROL_SEARCH_OPTIONS_OID, false, search_options);
+               }
+       }
+
        lreq->context = res;
-       lreq->callback = ldapsrv_SearchCallback;
+       lreq->callback = ldb_search_default_callback;
 
        /* Copy the timeout from the incoming call */
        ldb_set_timeout(samdb, lreq, req->timelimit);
@@ -270,7 +259,7 @@ static NTSTATUS ldapsrv_SearchRequest(struct ldapsrv_call *call)
                        NT_STATUS_HAVE_NO_MEMORY(ent_r);
 
                        ent = &ent_r->msg->r.SearchResultEntry;
-                       ent->dn = ldb_dn_linearize(ent_r, res->msgs[i]->dn);
+                       ent->dn = ldb_dn_alloc_linearized(ent_r, res->msgs[i]->dn);
                        ent->num_attributes = 0;
                        ent->attributes = NULL;
                        if (res->msgs[i]->num_elements == 0) {
@@ -352,7 +341,7 @@ static NTSTATUS ldapsrv_ModifyRequest(struct ldapsrv_call *call)
        local_ctx = talloc_named(call, 0, "ModifyRequest local memory context");
        NT_STATUS_HAVE_NO_MEMORY(local_ctx);
 
-       dn = ldb_dn_explode(local_ctx, req->dn);
+       dn = ldb_dn_new(local_ctx, samdb, req->dn);
        VALID_DN_SYNTAX(dn, 1);
 
        DEBUG(10, ("ModifyRequest: dn: [%s]\n", req->dn));
@@ -361,7 +350,6 @@ static NTSTATUS ldapsrv_ModifyRequest(struct ldapsrv_call *call)
        NT_STATUS_HAVE_NO_MEMORY(msg);
 
        msg->dn = dn;
-       msg->private_data = NULL;
        msg->num_elements = 0;
        msg->elements = NULL;
 
@@ -393,7 +381,8 @@ static NTSTATUS ldapsrv_ModifyRequest(struct ldapsrv_call *call)
 
                        msg->elements[i].num_values = req->mods[i].attrib.num_values;
                        if (msg->elements[i].num_values > 0) {
-                               msg->elements[i].values = talloc_array(msg, struct ldb_val, msg->elements[i].num_values);
+                               msg->elements[i].values = talloc_array(msg->elements, struct ldb_val,
+                                                                      msg->elements[i].num_values);
                                NT_STATUS_HAVE_NO_MEMORY(msg->elements[i].values);
 
                                for (j=0; j < msg->elements[i].num_values; j++) {
@@ -455,7 +444,7 @@ static NTSTATUS ldapsrv_AddRequest(struct ldapsrv_call *call)
        local_ctx = talloc_named(call, 0, "AddRequest local memory context");
        NT_STATUS_HAVE_NO_MEMORY(local_ctx);
 
-       dn = ldb_dn_explode(local_ctx, req->dn);
+       dn = ldb_dn_new(local_ctx, samdb, req->dn);
        VALID_DN_SYNTAX(dn,1);
 
        DEBUG(10, ("AddRequest: dn: [%s]\n", req->dn));
@@ -464,7 +453,6 @@ static NTSTATUS ldapsrv_AddRequest(struct ldapsrv_call *call)
        NT_STATUS_HAVE_NO_MEMORY(msg);
 
        msg->dn = dn;
-       msg->private_data = NULL;
        msg->num_elements = 0;
        msg->elements = NULL;
 
@@ -481,7 +469,8 @@ static NTSTATUS ldapsrv_AddRequest(struct ldapsrv_call *call)
                        
                        if (req->attributes[i].num_values > 0) {
                                msg->elements[i].num_values = req->attributes[i].num_values;
-                               msg->elements[i].values = talloc_array(msg, struct ldb_val, msg->elements[i].num_values);
+                               msg->elements[i].values = talloc_array(msg->elements, struct ldb_val,
+                                                                      msg->elements[i].num_values);
                                NT_STATUS_HAVE_NO_MEMORY(msg->elements[i].values);
 
                                for (j=0; j < msg->elements[i].num_values; j++) {
@@ -545,7 +534,7 @@ static NTSTATUS ldapsrv_DelRequest(struct ldapsrv_call *call)
        local_ctx = talloc_named(call, 0, "DelRequest local memory context");
        NT_STATUS_HAVE_NO_MEMORY(local_ctx);
 
-       dn = ldb_dn_explode(local_ctx, req->dn);
+       dn = ldb_dn_new(local_ctx, samdb, req->dn);
        VALID_DN_SYNTAX(dn,1);
 
        DEBUG(10, ("DelRequest: dn: [%s]\n", req->dn));
@@ -578,7 +567,7 @@ static NTSTATUS ldapsrv_ModifyDNRequest(struct ldapsrv_call *call)
        struct ldapsrv_reply *modifydn_r;
        void *local_ctx;
        struct ldb_context *samdb = call->conn->ldb;
-       struct ldb_dn *olddn, *newdn, *newrdn;
+       struct ldb_dn *olddn, *newdn=NULL, *newrdn;
        struct ldb_dn *parentdn = NULL;
        const char *errstr = NULL;
        int result = LDAP_SUCCESS;
@@ -591,10 +580,10 @@ static NTSTATUS ldapsrv_ModifyDNRequest(struct ldapsrv_call *call)
        local_ctx = talloc_named(call, 0, "ModifyDNRequest local memory context");
        NT_STATUS_HAVE_NO_MEMORY(local_ctx);
 
-       olddn = ldb_dn_explode(local_ctx, req->dn);
+       olddn = ldb_dn_new(local_ctx, samdb, req->dn);
        VALID_DN_SYNTAX(olddn, 2);
 
-       newrdn = ldb_dn_explode(local_ctx, req->newrdn);
+       newrdn = ldb_dn_new(local_ctx, samdb, req->newrdn);
        VALID_DN_SYNTAX(newrdn, 1);
 
        DEBUG(10, ("ModifyDNRequest: olddn: [%s]\n", req->dn));
@@ -607,18 +596,12 @@ static NTSTATUS ldapsrv_ModifyDNRequest(struct ldapsrv_call *call)
                goto reply;
        }
 
-       if (newrdn->comp_num > 1) {
-               result = LDAP_NAMING_VIOLATION;
-               errstr = "Error new RDN invalid";
-               goto reply;
-       }
-
        if (req->newsuperior) {
-               parentdn = ldb_dn_explode(local_ctx, req->newsuperior);
+               parentdn = ldb_dn_new(local_ctx, samdb, req->newsuperior);
                VALID_DN_SYNTAX(parentdn, 0);
                DEBUG(10, ("ModifyDNRequest: newsuperior: [%s]\n", req->newsuperior));
                
-               if (parentdn->comp_num < 1) {
+               if (ldb_dn_get_comp_num(parentdn) < 1) {
                        result = LDAP_AFFECTS_MULTIPLE_DSAS;
                        errstr = "Error new Superior DN invalid";
                        goto reply;
@@ -630,8 +613,14 @@ static NTSTATUS ldapsrv_ModifyDNRequest(struct ldapsrv_call *call)
                NT_STATUS_HAVE_NO_MEMORY(parentdn);
        }
 
-       newdn = ldb_dn_make_child(local_ctx, ldb_dn_get_rdn(local_ctx, newrdn), parentdn);
-       NT_STATUS_HAVE_NO_MEMORY(newdn);
+       if ( ! ldb_dn_add_child_fmt(parentdn,
+                               "%s=%s",
+                               ldb_dn_get_rdn_name(newrdn),
+                               (char *)ldb_dn_get_rdn_val(newrdn)->data)) {
+               result = LDAP_OTHER;
+               goto reply;
+       }
+       newdn = parentdn;
 
 reply:
        modifydn_r = ldapsrv_init_reply(call, LDAP_TAG_ModifyDNResponse);
@@ -675,7 +664,7 @@ static NTSTATUS ldapsrv_CompareRequest(struct ldapsrv_call *call)
        local_ctx = talloc_named(call, 0, "CompareRequest local_memory_context");
        NT_STATUS_HAVE_NO_MEMORY(local_ctx);
 
-       dn = ldb_dn_explode(local_ctx, req->dn);
+       dn = ldb_dn_new(local_ctx, samdb, req->dn);
        VALID_DN_SYNTAX(dn, 1);
 
        DEBUG(10, ("CompareRequest: dn: [%s]\n", req->dn));
@@ -693,7 +682,7 @@ reply:
 
        if (result == LDAP_SUCCESS) {
                ldb_ret = ldb_search(samdb, dn, LDB_SCOPE_BASE, filter, attrs, &res);
-               talloc_steal(samdb, res);
+               talloc_steal(local_ctx, res);
                if (ldb_ret != LDB_SUCCESS) {
                        result = map_ldb_error(samdb, ldb_ret, &errstr);
                        DEBUG(10,("CompareRequest: error: %s\n", errstr));