r12427: Move SAMR CreateUser2 to transactions, and re-add support for
[samba.git] / source / rpc_server / samr / dcesrv_samr.c
index 43cad59c7ab815d6fb47b89b62b8b856357cb89b..42be226022a3c7bbea193a135ca754ec2598f3bc 100644 (file)
 #include "rpc_server/samr/dcesrv_samr.h"
 #include "system/time.h"
 #include "lib/ldb/include/ldb.h"
+#include "ads.h"
 
 
 /*
   This is a bad temporary hack until we have at least some kind of schema
   support
 */
-static char *ldb_hexstr(TALLOC_CTX *mem_ctx, uint32 val)
+static char *ldb_hexstr(TALLOC_CTX *mem_ctx, uint32_t val)
 {
        return talloc_asprintf(mem_ctx, "0x%.8x", val);
 }
@@ -59,12 +60,13 @@ static NTSTATUS samr_Connect(struct dcesrv_call_state *dce_call, TALLOC_CTX *mem
        }
 
        /* make sure the sam database is accessible */
-       c_state->sam_ctx = samdb_connect(c_state);
+       c_state->sam_ctx = samdb_connect(c_state, dce_call->conn->auth_state.session_info); 
        if (c_state->sam_ctx == NULL) {
                talloc_free(c_state);
                return NT_STATUS_INVALID_SYSTEM_SERVICE;
        }
 
+
        handle = dcesrv_handle_new(dce_call->context, SAMR_HANDLE_CONNECT);
        if (!handle) {
                talloc_free(c_state);
@@ -159,32 +161,51 @@ static NTSTATUS samr_LookupDomain(struct dcesrv_call_state *dce_call, TALLOC_CTX
 {
        struct samr_connect_state *c_state;
        struct dcesrv_handle *h;
-       struct dom_sid2 *sid;
-       const char *sidstr;
-               
+       struct dom_sid *sid;
+       const char * const dom_attrs[] = { "objectSid", NULL};
+       const char * const ref_attrs[] = { "ncName", NULL};
+       struct ldb_message **dom_msgs;
+       struct ldb_message **ref_msgs;
+       int ret;
+
        r->out.sid = NULL;
 
        DCESRV_PULL_HANDLE(h, r->in.connect_handle, SAMR_HANDLE_CONNECT);
 
        c_state = h->data;
 
-       if (r->in.domain->string == NULL) {
+       if (r->in.domain_name->string == NULL) {
                return NT_STATUS_INVALID_PARAMETER;
        }
 
-       sidstr = samdb_search_string(c_state->sam_ctx,
-                                    mem_ctx, NULL, "objectSid",
-                                    "(&(name=%s)(objectclass=domain))",
-                                    r->in.domain->string);
-       if (sidstr == NULL) {
-               return NT_STATUS_NO_SUCH_DOMAIN;
+       if (strcasecmp(r->in.domain_name->string, "BUILTIN") == 0) {
+               ret = gendb_search(c_state->sam_ctx,
+                                  mem_ctx, NULL, &dom_msgs, dom_attrs,
+                                  "(objectClass=builtinDomain)");
+       } else {
+               ret = gendb_search(c_state->sam_ctx,
+                                  mem_ctx, NULL, &ref_msgs, ref_attrs,
+                                  "(&(&(nETBIOSName=%s)(objectclass=crossRef))(ncName=*))", 
+                                  ldb_binary_encode_string(mem_ctx, r->in.domain_name->string));
+               if (ret != 1) {
+                       return NT_STATUS_NO_SUCH_DOMAIN;
+               }
+               
+               ret = gendb_search_dn(c_state->sam_ctx, mem_ctx, 
+                                     samdb_result_dn(mem_ctx,
+                                                     ref_msgs[0], "ncName", NULL), 
+                                     &dom_msgs, dom_attrs);
        }
 
-       sid = dom_sid_parse_talloc(mem_ctx, sidstr);
+       if (ret != 1) {
+               return NT_STATUS_NO_SUCH_DOMAIN;
+       }
+       
+       sid = samdb_result_dom_sid(mem_ctx, dom_msgs[0],
+                                  "objectSid");
+               
        if (sid == NULL) {
-               DEBUG(0,("samdb: Invalid sid '%s' for domain %s\n",
-                        sidstr, r->in.domain->string));
-               return NT_STATUS_INTERNAL_DB_CORRUPTION;
+               return NT_STATUS_NO_SUCH_DOMAIN;
        }
 
        r->out.sid = sid;
@@ -204,8 +225,11 @@ static NTSTATUS samr_EnumDomains(struct dcesrv_call_state *dce_call, TALLOC_CTX
        struct samr_connect_state *c_state;
        struct dcesrv_handle *h;
        struct samr_SamArray *array;
-       const char **domains;
        int count, i, start_i;
+       const char * const dom_attrs[] = { "cn", NULL};
+       const char * const ref_attrs[] = { "nETBIOSName", NULL};
+       struct ldb_message **dom_msgs;
+       struct ldb_message **ref_msgs;
 
        *r->out.resume_handle = 0;
        r->out.sam = NULL;
@@ -215,9 +239,9 @@ static NTSTATUS samr_EnumDomains(struct dcesrv_call_state *dce_call, TALLOC_CTX
 
        c_state = h->data;
 
-       count = samdb_search_string_multiple(c_state->sam_ctx,
-                                            mem_ctx, NULL, &domains, 
-                                            "name", "(objectclass=domain)");
+       count = gendb_search(c_state->sam_ctx,
+                          mem_ctx, NULL, &dom_msgs, dom_attrs,
+                          "(objectClass=domain)");
        if (count == -1) {
                DEBUG(0,("samdb: no domains found in EnumDomains\n"));
                return NT_STATUS_INTERNAL_DB_CORRUPTION;
@@ -246,8 +270,18 @@ static NTSTATUS samr_EnumDomains(struct dcesrv_call_state *dce_call, TALLOC_CTX
        }
 
        for (i=0;i<count-start_i;i++) {
+               int ret;
                array->entries[i].idx = start_i + i;
-               array->entries[i].name.string = domains[start_i+i];
+               /* try and find the domain */
+               ret = gendb_search(c_state->sam_ctx, mem_ctx, NULL, 
+                                  &ref_msgs, ref_attrs, 
+                                  "(&(objectClass=crossRef)(ncName=%s))", 
+                                  ldb_dn_linearize(mem_ctx, dom_msgs[i]->dn));
+               if (ret == 1) {
+                       array->entries[i].name.string = samdb_result_string(ref_msgs[0], "nETBIOSName", NULL);
+               } else {
+                       array->entries[i].name.string = samdb_result_string(dom_msgs[i], "cn", NULL);
+               }
        }
 
        r->out.sam = array;
@@ -265,11 +299,13 @@ static NTSTATUS samr_OpenDomain(struct dcesrv_call_state *dce_call, TALLOC_CTX *
                                struct samr_OpenDomain *r)
 {
        struct dcesrv_handle *h_conn, *h_domain;
-       const char *sidstr, *domain_name;
+       const char *domain_name;
        struct samr_connect_state *c_state;
        struct samr_domain_state *d_state;
-       const char * const attrs[2] = { "name", NULL};
-       struct ldb_message **msgs;
+       const char * const dom_attrs[] = { "cn", NULL};
+       const char * const ref_attrs[] = { "nETBIOSName", NULL};
+       struct ldb_message **dom_msgs;
+       struct ldb_message **ref_msgs;
        int ret;
 
        ZERO_STRUCTP(r->out.domain_handle);
@@ -282,22 +318,31 @@ static NTSTATUS samr_OpenDomain(struct dcesrv_call_state *dce_call, TALLOC_CTX *
                return NT_STATUS_INVALID_PARAMETER;
        }
 
-       sidstr = dom_sid_string(mem_ctx, r->in.sid);
-       if (sidstr == NULL) {
-               return NT_STATUS_INVALID_PARAMETER;
-       }
-
-       ret = samdb_search(c_state->sam_ctx,
-                          mem_ctx, NULL, &msgs, attrs,
-                          "(&(objectSid=%s)(objectclass=domain))", 
-                          sidstr);
+       ret = gendb_search(c_state->sam_ctx,
+                          mem_ctx, NULL, &dom_msgs, dom_attrs,
+                          "(&(objectSid=%s)(&(objectclass=domain)))",
+                          ldap_encode_ndr_dom_sid(mem_ctx, r->in.sid));
        if (ret != 1) {
-               return NT_STATUS_NO_SUCH_DOMAIN;
-       }
-
-       domain_name = ldb_msg_find_string(msgs[0], "name", NULL);
-       if (domain_name == NULL) {
-               return NT_STATUS_NO_SUCH_DOMAIN;
+               return NT_STATUS_INTERNAL_DB_CORRUPTION;
+       } else {
+               ret = gendb_search(c_state->sam_ctx,
+                                  mem_ctx, NULL, &ref_msgs, ref_attrs,
+                                  "(&(&(nETBIOSName=*)(objectclass=crossRef))(ncName=%s))", 
+                                  ldb_dn_linearize(mem_ctx, dom_msgs[0]->dn));
+               if (ret == 0) {
+                       domain_name = ldb_msg_find_string(dom_msgs[0], "cn", NULL);
+                       if (domain_name == NULL) {
+                               return NT_STATUS_NO_SUCH_DOMAIN;
+                       }
+               } else if (ret == 1) {
+               
+                       domain_name = ldb_msg_find_string(ref_msgs[0], "nETBIOSName", NULL);
+                       if (domain_name == NULL) {
+                               return NT_STATUS_NO_SUCH_DOMAIN;
+                       }
+               } else {
+                       return NT_STATUS_NO_SUCH_DOMAIN;
+               }
        }
 
        d_state = talloc(c_state, struct samr_domain_state);
@@ -307,9 +352,9 @@ static NTSTATUS samr_OpenDomain(struct dcesrv_call_state *dce_call, TALLOC_CTX *
 
        d_state->connect_state = talloc_reference(d_state, c_state);
        d_state->sam_ctx = c_state->sam_ctx;
-       d_state->domain_sid = talloc_strdup(d_state, sidstr);
+       d_state->domain_sid = dom_sid_dup(d_state, r->in.sid);
        d_state->domain_name = talloc_strdup(d_state, domain_name);
-       d_state->domain_dn = talloc_strdup(d_state, msgs[0]->dn);
+       d_state->domain_dn = ldb_dn_copy(d_state, dom_msgs[0]->dn);
        if (!d_state->domain_sid || !d_state->domain_name || !d_state->domain_dn) {
                talloc_free(d_state);
                return NT_STATUS_NO_MEMORY;             
@@ -342,8 +387,8 @@ static NTSTATUS samr_info_DomInfo1(struct samr_domain_state *state,
        int ret;
        struct ldb_message **res;
 
-       ret = samdb_search(state->sam_ctx, mem_ctx, NULL, &res, attrs, 
-                          "dn=%s", state->domain_dn);
+       ret = gendb_search_dn(state->sam_ctx, mem_ctx,
+                             state->domain_dn , &res, attrs);
        if (ret != 1) {
                return NT_STATUS_INTERNAL_DB_CORRUPTION;
        }
@@ -368,21 +413,23 @@ static NTSTATUS samr_info_DomInfo1(struct samr_domain_state *state,
 static NTSTATUS samr_info_DomInfo2(struct samr_domain_state *state, TALLOC_CTX *mem_ctx,
                                   struct samr_DomInfo2 *info)
 {
-       const char * const attrs[] = { "comment", "name", NULL };
+       const char * const dom_attrs[] = { "comment", NULL };
        int ret;
-       struct ldb_message **res;
-
-       ret = samdb_search(state->sam_ctx, mem_ctx, NULL, &res, attrs, 
-                          "dn=%s", state->domain_dn);
+       struct ldb_message **dom_msgs;
+       const char *domain_name;
+       
+       ret = gendb_search_dn(state->sam_ctx, mem_ctx,
+                             state->domain_dn, &dom_msgs, dom_attrs);
        if (ret != 1) {
                return NT_STATUS_INTERNAL_DB_CORRUPTION;
        }
 
+       domain_name = state->domain_name;
        /* where is this supposed to come from? is it settable? */
        info->force_logoff_time = 0x8000000000000000LL;
 
-       info->comment.string = samdb_result_string(res[0], "comment", NULL);
-       info->domain.string  = samdb_result_string(res[0], "name", NULL);
+       info->comment.string = samdb_result_string(dom_msgs[0], "comment", NULL);
+       info->domain_name.string  = domain_name;
 
        info->primary.string = lp_netbios_name();
        info->sequence_num = 0;
@@ -468,11 +515,10 @@ static NTSTATUS samr_CreateDomainGroup(struct dcesrv_call_state *dce_call, TALLO
        struct dcesrv_handle *h;
        const char *name;
        struct ldb_message *msg;
-       uint32_t rid;
-       const char *groupname, *sidstr;
+       struct dom_sid *sid;
+       const char *groupname;
        struct dcesrv_handle *g_handle;
        int ret;
-       NTSTATUS status;
 
        ZERO_STRUCTP(r->out.group_handle);
        *r->out.rid = 0;
@@ -491,7 +537,7 @@ static NTSTATUS samr_CreateDomainGroup(struct dcesrv_call_state *dce_call, TALLO
        name = samdb_search_string(d_state->sam_ctx, mem_ctx, NULL, 
                                   "sAMAccountName",
                                   "(&(sAMAccountName=%s)(objectclass=group))",
-                                  groupname);
+                                  ldb_binary_encode_string(mem_ctx, groupname));
        if (name != NULL) {
                return NT_STATUS_GROUP_EXISTS;
        }
@@ -501,43 +547,20 @@ static NTSTATUS samr_CreateDomainGroup(struct dcesrv_call_state *dce_call, TALLO
                return NT_STATUS_NO_MEMORY;
        }
 
-       /* pull in all the template attributes */
-       ret = samdb_copy_template(d_state->sam_ctx, mem_ctx, msg, 
-                                 "(&(name=TemplateGroup)(objectclass=groupTemplate))");
-       if (ret != 0) {
-               DEBUG(0,("Failed to load TemplateGroup from samdb\n"));
-               return NT_STATUS_INTERNAL_DB_CORRUPTION;
-       }
-
-       /* allocate a rid */
-       status = samdb_allocate_next_id(d_state->sam_ctx, mem_ctx, 
-                                       d_state->domain_dn, "nextRid", &rid);
-       if (!NT_STATUS_IS_OK(status)) {
-               return status;
-       }
-
-       /* and the group SID */
-       sidstr = talloc_asprintf(mem_ctx, "%s-%u", d_state->domain_sid, rid);
-       if (!sidstr) {
-               return NT_STATUS_NO_MEMORY;
-       }
-
        /* add core elements to the ldb_message for the user */
-       msg->dn = talloc_asprintf(mem_ctx, "CN=%s,CN=Users,%s", groupname,
-                                 d_state->domain_dn);
+       msg->dn = ldb_dn_string_compose(mem_ctx, d_state->domain_dn,
+                                       "CN=%s, CN=Users", groupname);
        if (!msg->dn) {
                return NT_STATUS_NO_MEMORY;
        }
-       samdb_msg_add_string(d_state->sam_ctx, mem_ctx, msg, "name", groupname);
-       samdb_msg_add_string(d_state->sam_ctx, mem_ctx, msg, "cn", groupname);
        samdb_msg_add_string(d_state->sam_ctx, mem_ctx, msg, "sAMAccountName", groupname);
        samdb_msg_add_string(d_state->sam_ctx, mem_ctx, msg, "objectClass", "group");
-       samdb_msg_add_string(d_state->sam_ctx, mem_ctx, msg, "objectSid", sidstr);
                             
        /* create the group */
        ret = samdb_add(d_state->sam_ctx, mem_ctx, msg);
        if (ret != 0) {
-               DEBUG(0,("Failed to create group record %s\n", msg->dn));
+               DEBUG(0,("Failed to create group record %s\n",
+                        ldb_dn_linearize(mem_ctx, msg->dn)));
                return NT_STATUS_INTERNAL_DB_CORRUPTION;
        }
 
@@ -549,7 +572,14 @@ static NTSTATUS samr_CreateDomainGroup(struct dcesrv_call_state *dce_call, TALLO
        a_state->access_mask = r->in.access_mask;
        a_state->domain_state = talloc_reference(a_state, d_state);
        a_state->account_dn = talloc_steal(a_state, msg->dn);
-       a_state->account_sid = talloc_steal(a_state, sidstr);
+
+       /* retrieve the sid for the group just created */
+       sid = samdb_search_dom_sid(d_state->sam_ctx, a_state,
+                                  msg->dn, "objectSid", NULL);
+       if (sid == NULL) {
+               return NT_STATUS_UNSUCCESSFUL;
+       }
+
        a_state->account_name = talloc_strdup(a_state, groupname);
        if (!a_state->account_name) {
                return NT_STATUS_NO_MEMORY;
@@ -564,7 +594,7 @@ static NTSTATUS samr_CreateDomainGroup(struct dcesrv_call_state *dce_call, TALLO
        g_handle->data = talloc_steal(g_handle, a_state);
 
        *r->out.group_handle = g_handle->wire_handle;
-       *r->out.rid = rid;      
+       *r->out.rid = sid->sub_auths[sid->num_auths-1];
 
        return NT_STATUS_OK;
 }
@@ -590,7 +620,6 @@ static NTSTATUS samr_EnumDomainGroups(struct dcesrv_call_state *dce_call, TALLOC
        int ldb_cnt, count, i, first;
        struct samr_SamEntry *entries;
        const char * const attrs[3] = { "objectSid", "sAMAccountName", NULL };
-       struct dom_sid *domain_sid;
 
        *r->out.resume_handle = 0;
        r->out.sam = NULL;
@@ -600,15 +629,11 @@ static NTSTATUS samr_EnumDomainGroups(struct dcesrv_call_state *dce_call, TALLOC
 
        d_state = h->data;
 
-       domain_sid = dom_sid_parse_talloc(mem_ctx, d_state->domain_sid);
-       if (domain_sid == NULL)
-               return NT_STATUS_NO_MEMORY;
-       
        /* search for all domain groups in this domain. This could possibly be
           cached and resumed based on resume_key */
        ldb_cnt = samdb_search_domain(d_state->sam_ctx, mem_ctx,
                                      d_state->domain_dn, &res, attrs,
-                                     domain_sid,
+                                     d_state->domain_sid,
                                      "(&(grouptype=%s)(objectclass=group))",
                                      ldb_hexstr(mem_ctx,
                                                 GTYPE_SECURITY_GLOBAL_GROUP));
@@ -691,12 +716,23 @@ static NTSTATUS samr_CreateUser2(struct dcesrv_call_state *dce_call, TALLOC_CTX
        struct dcesrv_handle *h;
        const char *name;
        struct ldb_message *msg;
-       uint32_t rid;
-       const char *account_name, *sidstr;
+       struct dom_sid *sid;
+       const char *account_name;
        struct dcesrv_handle *u_handle;
        int ret;
-       NTSTATUS status;
-       const char *container, *additional_class=NULL;
+       const char *container, *obj_class=NULL;
+       char *cn_name;
+       int cn_name_len;
+
+       const char *attrs[] = {
+               "objectSid", 
+               "userAccountControl",
+               NULL
+       };
+
+       uint32_t user_account_control;
+
+       struct ldb_message **msgs;
 
        ZERO_STRUCTP(r->out.user_handle);
        *r->out.access_granted = 0;
@@ -712,115 +748,146 @@ static NTSTATUS samr_CreateUser2(struct dcesrv_call_state *dce_call, TALLOC_CTX
                return NT_STATUS_INVALID_PARAMETER;
        }
 
+       ret = ldb_transaction_start(d_state->sam_ctx);
+       if (ret != 0) {
+               DEBUG(0,("Failed to start a transaction for user creation\n"));
+               return NT_STATUS_INTERNAL_DB_CORRUPTION;
+       }
+
        /* check if the user already exists */
        name = samdb_search_string(d_state->sam_ctx, mem_ctx, NULL, 
                                   "sAMAccountName", 
-                                  "(&(sAMAccountName=%s)(objectclass=user))", account_name);
+                                  "(&(sAMAccountName=%s)(objectclass=user))", 
+                                  ldb_binary_encode_string(mem_ctx, account_name));
        if (name != NULL) {
+               ldb_transaction_cancel(d_state->sam_ctx);
                return NT_STATUS_USER_EXISTS;
        }
 
        msg = ldb_msg_new(mem_ctx);
        if (msg == NULL) {
+               ldb_transaction_cancel(d_state->sam_ctx);
                return NT_STATUS_NO_MEMORY;
        }
 
+       cn_name   = talloc_strdup(mem_ctx, account_name);
+       NT_STATUS_HAVE_NO_MEMORY(cn_name);
+       cn_name_len = strlen(cn_name);
+
        /* This must be one of these values *only* */
        if (r->in.acct_flags == ACB_NORMAL) {
-               /* pull in all the template attributes */
-               ret = samdb_copy_template(d_state->sam_ctx, mem_ctx, msg, 
-                                         "(&(name=TemplateUser)(objectclass=userTemplate))");
-               if (ret != 0) {
-                       DEBUG(0,("Failed to load TemplateUser from samdb\n"));
-                       return NT_STATUS_INTERNAL_DB_CORRUPTION;
-               }
-
                container = "Users";
+               obj_class = "user";
 
        } else if (r->in.acct_flags == ACB_WSTRUST) {
-               /* pull in all the template attributes */
-               ret = samdb_copy_template(d_state->sam_ctx, mem_ctx, msg, 
-                                         "(&(name=TemplateMemberServer)(objectclass=userTemplate))");
-               if (ret != 0) {
-                       DEBUG(0,("Failed to load TemplateMemberServer from samdb\n"));
-                       return NT_STATUS_INTERNAL_DB_CORRUPTION;
+               if (cn_name[cn_name_len - 1] != '$') {
+                       return NT_STATUS_FOOBAR;
                }
-
+               cn_name[cn_name_len - 1] = '\0';
                container = "Computers";
-               additional_class = "computer";
+               obj_class = "computer";
 
        } else if (r->in.acct_flags == ACB_SVRTRUST) {
-               /* pull in all the template attributes */
-               ret = samdb_copy_template(d_state->sam_ctx, mem_ctx, msg, 
-                                         "(&(name=TemplateDomainController)(objectclass=userTemplate))");
-               if (ret != 0) {
-                       DEBUG(0,("Failed to load TemplateDomainController from samdb\n"));
-                       return NT_STATUS_INTERNAL_DB_CORRUPTION;
+               if (cn_name[cn_name_len - 1] != '$') {
+                       return NT_STATUS_FOOBAR;                
                }
-
+               cn_name[cn_name_len - 1] = '\0';
                container = "Domain Controllers";
-               additional_class = "computer";
+               obj_class = "computer";
 
        } else if (r->in.acct_flags == ACB_DOMTRUST) {
-               /* pull in all the template attributes */
-               ret = samdb_copy_template(d_state->sam_ctx, mem_ctx, msg, 
-                                         "(&(name=TemplateTrustingDomain)(objectclass=userTemplate))");
-               if (ret != 0) {
-                       DEBUG(0,("Failed to load TemplateTrustingDomain from samdb\n"));
-                       return NT_STATUS_INTERNAL_DB_CORRUPTION;
-               }
-
                container = "Users";
-               additional_class = "computer";
+               obj_class = "user";
 
        } else {
+               ldb_transaction_cancel(d_state->sam_ctx);
                return NT_STATUS_INVALID_PARAMETER;
        }
 
-       /* allocate a rid */
-       status = samdb_allocate_next_id(d_state->sam_ctx, mem_ctx, 
-                                       d_state->domain_dn, "nextRid", &rid);
-       if (!NT_STATUS_IS_OK(status)) {
-               return status;
-       }
-
-       /* and the users SID */
-       sidstr = talloc_asprintf(mem_ctx, "%s-%u", d_state->domain_sid, rid);
-       if (!sidstr) {
-               return NT_STATUS_NO_MEMORY;
-       }
-
        /* add core elements to the ldb_message for the user */
-       msg->dn = talloc_asprintf(mem_ctx, "CN=%s,CN=%s,%s", account_name, container, d_state->domain_dn);
+       msg->dn = ldb_dn_build_child(mem_ctx, "CN", cn_name, ldb_dn_build_child(mem_ctx, "CN", container, d_state->domain_dn));
        if (!msg->dn) {
+               ldb_transaction_cancel(d_state->sam_ctx);
                return NT_STATUS_NO_MEMORY;             
        }
-       samdb_msg_add_string(d_state->sam_ctx, mem_ctx, msg, "name", account_name);
-       samdb_msg_add_string(d_state->sam_ctx, mem_ctx, msg, "cn", account_name);
        samdb_msg_add_string(d_state->sam_ctx, mem_ctx, msg, "sAMAccountName", account_name);
-       samdb_msg_add_string(d_state->sam_ctx, mem_ctx, msg, "objectClass", "user");
-       if (additional_class) {
-               samdb_msg_add_string(d_state->sam_ctx, mem_ctx, msg, "objectClass", additional_class);
-       }
-       samdb_msg_add_string(d_state->sam_ctx, mem_ctx, msg, "objectSid", sidstr);
-
+       samdb_msg_add_string(d_state->sam_ctx, mem_ctx, msg, "objectClass", obj_class);
+       
+       /* Start a transaction, so we can query and do a subsequent atomic modify */
+       
        /* create the user */
        ret = samdb_add(d_state->sam_ctx, mem_ctx, msg);
        if (ret != 0) {
-               DEBUG(0,("Failed to create user record %s\n", msg->dn));
+               ldb_transaction_cancel(d_state->sam_ctx);
+               DEBUG(0,("Failed to create user record %s\n",
+                        ldb_dn_linearize(mem_ctx, msg->dn)));
                return NT_STATUS_INTERNAL_DB_CORRUPTION;
        }
 
        a_state = talloc(d_state, struct samr_account_state);
        if (!a_state) {
+               ldb_transaction_cancel(d_state->sam_ctx);
                return NT_STATUS_NO_MEMORY;
        }
        a_state->sam_ctx = d_state->sam_ctx;
        a_state->access_mask = r->in.access_mask;
        a_state->domain_state = talloc_reference(a_state, d_state);
        a_state->account_dn = talloc_steal(a_state, msg->dn);
-       a_state->account_sid = talloc_steal(a_state, sidstr);
-       a_state->account_name = talloc_strdup(a_state, account_name);
+
+       /* retrieve the sid and account control bits for the user just created */
+       ret = gendb_search_dn(d_state->sam_ctx, a_state,
+                             msg->dn, &msgs, attrs);
+
+       if (ret != 1) {
+               ldb_transaction_cancel(d_state->sam_ctx);
+               DEBUG(0,("Apparently we failed to create an account record, as %s now doesn't exist\n",
+                        ldb_dn_linearize(mem_ctx, msg->dn)));
+               return NT_STATUS_INTERNAL_DB_CORRUPTION;
+       }
+       sid = samdb_result_dom_sid(mem_ctx, msgs[0], "objectSid");
+       if (sid == NULL) {
+               return NT_STATUS_INTERNAL_DB_CORRUPTION;
+       }
+
+       user_account_control = samdb_result_uint(msgs[0], "userAccountControl", 0);
+       user_account_control = (user_account_control & ~(UF_NORMAL_ACCOUNT|UF_INTERDOMAIN_TRUST_ACCOUNT|UF_WORKSTATION_TRUST_ACCOUNT|UF_SERVER_TRUST_ACCOUNT));
+       user_account_control |= samdb_acb2uf(r->in.acct_flags);
+
+       talloc_free(msg);
+       msg = ldb_msg_new(mem_ctx);
+       if (msg == NULL) {
+               ldb_transaction_cancel(d_state->sam_ctx);
+               return NT_STATUS_NO_MEMORY;
+       }
+
+       msg->dn = a_state->account_dn;
+
+       if (samdb_msg_add_uint(a_state->sam_ctx, mem_ctx, msg, 
+                              "userAccountControl", 
+                              user_account_control) != 0) { 
+               ldb_transaction_cancel(d_state->sam_ctx);
+               return NT_STATUS_NO_MEMORY; 
+       }
+
+       /* modify the samdb record */
+       ret = samdb_replace(a_state->sam_ctx, mem_ctx, msg);
+       if (ret != 0) {
+               DEBUG(0,("Failed to modify account record %s to set userAccountControl\n",
+                        ldb_dn_linearize(mem_ctx, msg->dn)));
+               ldb_transaction_cancel(d_state->sam_ctx);
+
+               /* we really need samdb.c to return NTSTATUS */
+               return NT_STATUS_UNSUCCESSFUL;
+       }
+
+       ldb_transaction_commit(d_state->sam_ctx);
+       if (ret != 0) {
+               DEBUG(0,("Failed to commit transaction to add and modify account record %s\n",
+                        ldb_dn_linearize(mem_ctx, msg->dn)));
+               return NT_STATUS_INTERNAL_DB_CORRUPTION;
+       }
+
+       a_state->account_name = talloc_steal(a_state, account_name);
        if (!a_state->account_name) {
                return NT_STATUS_NO_MEMORY;
        }
@@ -835,7 +902,8 @@ static NTSTATUS samr_CreateUser2(struct dcesrv_call_state *dce_call, TALLOC_CTX
 
        *r->out.user_handle = u_handle->wire_handle;
        *r->out.access_granted = 0xf07ff; /* TODO: fix access mask calculations */
-       *r->out.rid = rid;      
+
+       *r->out.rid = sid->sub_auths[sid->num_auths-1];
 
        return NT_STATUS_OK;
 }
@@ -886,7 +954,7 @@ static NTSTATUS samr_EnumDomainUsers(struct dcesrv_call_state *dce_call, TALLOC_
        
        /* search for all users in this domain. This could possibly be cached and 
           resumed based on resume_key */
-       count = samdb_search(d_state->sam_ctx, mem_ctx, d_state->domain_dn, &res, attrs, 
+       count = gendb_search(d_state->sam_ctx, mem_ctx, d_state->domain_dn, &res, attrs, 
                             "objectclass=user");
        if (count == -1) {
                return NT_STATUS_INTERNAL_DB_CORRUPTION;
@@ -950,12 +1018,11 @@ static NTSTATUS samr_CreateDomAlias(struct dcesrv_call_state *dce_call, TALLOC_C
        struct samr_domain_state *d_state;
        struct samr_account_state *a_state;
        struct dcesrv_handle *h;
-       const char *aliasname, *name, *sidstr;
+       const char *alias_name, *name;
        struct ldb_message *msg;
-       uint32_t rid;
+       struct dom_sid *sid;
        struct dcesrv_handle *a_handle;
        int ret;
-       NTSTATUS status;
 
        ZERO_STRUCTP(r->out.alias_handle);
        *r->out.rid = 0;
@@ -964,17 +1031,17 @@ static NTSTATUS samr_CreateDomAlias(struct dcesrv_call_state *dce_call, TALLOC_C
 
        d_state = h->data;
 
-       aliasname = r->in.aliasname->string;
+       alias_name = r->in.alias_name->string;
 
-       if (aliasname == NULL) {
+       if (alias_name == NULL) {
                return NT_STATUS_INVALID_PARAMETER;
        }
 
        /* Check if alias already exists */
        name = samdb_search_string(d_state->sam_ctx, mem_ctx, NULL,
                                   "sAMAccountName",
-                                  "(&(sAMAccountName=%s)(objectclass=group))",
-                                  aliasname);
+                                  "(sAMAccountName=%s)(objectclass=group))",
+                                  ldb_binary_encode_string(mem_ctx, alias_name));
 
        if (name != NULL) {
                return NT_STATUS_ALIAS_EXISTS;
@@ -985,45 +1052,22 @@ static NTSTATUS samr_CreateDomAlias(struct dcesrv_call_state *dce_call, TALLOC_C
                return NT_STATUS_NO_MEMORY;
        }
 
-       /* pull in all the template attributes */
-       ret = samdb_copy_template(d_state->sam_ctx, mem_ctx, msg, 
-                                 "(&(name=TemplateAlias)"
-                                 "(objectclass=aliasTemplate))");
-       if (ret != 0) {
-               DEBUG(0,("Failed to load TemplateAlias from samdb\n"));
-               return NT_STATUS_INTERNAL_DB_CORRUPTION;
-       }
-
-       /* allocate a rid */
-       status = samdb_allocate_next_id(d_state->sam_ctx, mem_ctx, 
-                                       d_state->domain_dn, "nextRid", &rid);
-       if (!NT_STATUS_IS_OK(status)) {
-               return status;
-       }
-
-       /* and the group SID */
-       sidstr = talloc_asprintf(mem_ctx, "%s-%u", d_state->domain_sid, rid);
-       if (!sidstr) {
-               return NT_STATUS_NO_MEMORY;
-       }
-
        /* add core elements to the ldb_message for the alias */
-       msg->dn = talloc_asprintf(mem_ctx, "CN=%s,CN=Users,%s", aliasname,
-                                d_state->domain_dn);
+       msg->dn = ldb_dn_string_compose(mem_ctx, d_state->domain_dn,
+                                       "CN=%s, CN=Users", alias_name);
        if (!msg->dn) {
                return NT_STATUS_NO_MEMORY;
        }
 
-       samdb_msg_add_string(d_state->sam_ctx, mem_ctx, msg, "name", aliasname);
-       samdb_msg_add_string(d_state->sam_ctx, mem_ctx, msg, "cn", aliasname);
-       samdb_msg_add_string(d_state->sam_ctx, mem_ctx, msg, "sAMAccountName", aliasname);
+       samdb_msg_add_string(d_state->sam_ctx, mem_ctx, msg, "sAMAccountName", alias_name);
        samdb_msg_add_string(d_state->sam_ctx, mem_ctx, msg, "objectClass", "group");
-       samdb_msg_add_string(d_state->sam_ctx, mem_ctx, msg, "objectSid", sidstr);
+       samdb_msg_add_string(d_state->sam_ctx, mem_ctx, msg, "groupType", "0x80000004");
 
        /* create the alias */
        ret = samdb_add(d_state->sam_ctx, mem_ctx, msg);
        if (ret != 0) {
-               DEBUG(0,("Failed to create alias record %s\n", msg->dn));
+               DEBUG(0,("Failed to create alias record %s\n",
+                        ldb_dn_linearize(mem_ctx, msg->dn)));
                return NT_STATUS_INTERNAL_DB_CORRUPTION;
        }
 
@@ -1036,8 +1080,12 @@ static NTSTATUS samr_CreateDomAlias(struct dcesrv_call_state *dce_call, TALLOC_C
        a_state->access_mask = r->in.access_mask;
        a_state->domain_state = talloc_reference(a_state, d_state);
        a_state->account_dn = talloc_steal(a_state, msg->dn);
-       a_state->account_sid = talloc_steal(a_state, sidstr);
-       a_state->account_name = talloc_strdup(a_state, aliasname);
+
+       /* retrieve the sid for the alias just created */
+       sid = samdb_search_dom_sid(d_state->sam_ctx, a_state,
+                                  msg->dn, "objectSid", NULL);
+
+       a_state->account_name = talloc_strdup(a_state, alias_name);
        if (!a_state->account_name) {
                return NT_STATUS_NO_MEMORY;
        }
@@ -1050,7 +1098,8 @@ static NTSTATUS samr_CreateDomAlias(struct dcesrv_call_state *dce_call, TALLOC_C
        a_handle->data = talloc_steal(a_handle, a_state);
 
        *r->out.alias_handle = a_handle->wire_handle;
-       *r->out.rid = rid;
+
+       *r->out.rid = sid->sub_auths[sid->num_auths-1];
 
        return NT_STATUS_OK;
 }
@@ -1068,7 +1117,6 @@ static NTSTATUS samr_EnumDomainAliases(struct dcesrv_call_state *dce_call, TALLO
        int ldb_cnt, count, i, first;
        struct samr_SamEntry *entries;
        const char * const attrs[3] = { "objectSid", "sAMAccountName", NULL };
-       struct dom_sid *domain_sid;
 
        *r->out.resume_handle = 0;
        r->out.sam = NULL;
@@ -1078,15 +1126,12 @@ static NTSTATUS samr_EnumDomainAliases(struct dcesrv_call_state *dce_call, TALLO
 
        d_state = h->data;
 
-       domain_sid = dom_sid_parse_talloc(mem_ctx, d_state->domain_sid);
-       if (domain_sid == NULL)
-               return NT_STATUS_NO_MEMORY;
-       
        /* search for all domain groups in this domain. This could possibly be
           cached and resumed based on resume_key */
        ldb_cnt = samdb_search_domain(d_state->sam_ctx, mem_ctx,
                                      d_state->domain_dn,
-                                     &res, attrs, domain_sid,
+                                     &res, attrs, 
+                                     d_state->domain_sid,
                                      "(&(|(grouptype=%s)(grouptype=%s)))"
                                      "(objectclass=group))",
                                      ldb_hexstr(mem_ctx,
@@ -1167,7 +1212,6 @@ static NTSTATUS samr_GetAliasMembership(struct dcesrv_call_state *dce_call, TALL
        struct dcesrv_handle *h;
        struct samr_domain_state *d_state;
        struct ldb_message **res;
-       struct dom_sid *domain_sid;
        int i, count = 0;
 
        DCESRV_PULL_HANDLE(h, r->in.domain_handle, SAMR_HANDLE_DOMAIN);
@@ -1189,17 +1233,14 @@ static NTSTATUS samr_GetAliasMembership(struct dcesrv_call_state *dce_call, TALL
                        return NT_STATUS_NO_MEMORY;
 
                for (i=0; i<r->in.sids->num_sids; i++) {
-                       const char *sidstr, *memberdn;
-
-                       sidstr = dom_sid_string(mem_ctx,
-                                               r->in.sids->sids[i].sid);
-                       if (sidstr == NULL)
-                               return NT_STATUS_NO_MEMORY;
+                       const char *memberdn;
 
-                       memberdn = samdb_search_string(d_state->sam_ctx,
-                                                      mem_ctx, NULL, "dn",
-                                                      "(objectSid=%s)",
-                                                      sidstr);
+                       memberdn = 
+                               samdb_search_string(d_state->sam_ctx,
+                                                   mem_ctx, NULL, "distinguishedName",
+                                                   "(objectSid=%s)",
+                                                   ldap_encode_ndr_dom_sid(mem_ctx, 
+                                                                           r->in.sids->sids[i].sid));
 
                        if (memberdn == NULL)
                                continue;
@@ -1210,14 +1251,9 @@ static NTSTATUS samr_GetAliasMembership(struct dcesrv_call_state *dce_call, TALL
                                return NT_STATUS_NO_MEMORY;
                }
 
-               domain_sid = dom_sid_parse_talloc(mem_ctx,
-                                                 d_state->domain_sid);
-               if (domain_sid == NULL)
-                       return NT_STATUS_NO_MEMORY;
-
                count = samdb_search_domain(d_state->sam_ctx, mem_ctx,
                                            d_state->domain_dn, &res, attrs,
-                                           domain_sid, "%s))", filter);
+                                           d_state->domain_sid, "%s))", filter);
                if (count < 0)
                        return NT_STATUS_INTERNAL_DB_CORRUPTION;
        }
@@ -1280,32 +1316,26 @@ static NTSTATUS samr_LookupNames(struct dcesrv_call_state *dce_call, TALLOC_CTX
 
        for (i=0;i<r->in.num_names;i++) {
                struct ldb_message **res;
-               struct dom_sid2 *sid;
-               const char *sidstr;
+               struct dom_sid *sid;
                uint32_t atype, rtype;
 
                r->out.rids.ids[i] = 0;
                r->out.types.ids[i] = SID_NAME_UNKNOWN;
 
-               count = samdb_search(d_state->sam_ctx, mem_ctx, d_state->domain_dn, &res, attrs, 
-                                    "sAMAccountName=%s", r->in.names[i].string);
+               count = gendb_search(d_state->sam_ctx, mem_ctx, d_state->domain_dn, &res, attrs, 
+                                    "sAMAccountName=%s", 
+                                    ldb_binary_encode_string(mem_ctx, r->in.names[i].string));
                if (count != 1) {
                        status = STATUS_SOME_UNMAPPED;
                        continue;
                }
 
-               sidstr = samdb_result_string(res[0], "objectSid", NULL);
-               if (sidstr == NULL) {
-                       status = STATUS_SOME_UNMAPPED;
-                       continue;
-               }
-               
-               sid = dom_sid_parse_talloc(mem_ctx, sidstr);
+               sid = samdb_result_dom_sid(mem_ctx, res[0], "objectSid");
                if (sid == NULL) {
                        status = STATUS_SOME_UNMAPPED;
                        continue;
                }
-
+               
                atype = samdb_result_uint(res[0], "sAMAccountType", 0);
                if (atype == 0) {
                        status = STATUS_SOME_UNMAPPED;
@@ -1336,9 +1366,9 @@ static NTSTATUS samr_LookupRids(struct dcesrv_call_state *dce_call, TALLOC_CTX *
 {
        struct dcesrv_handle *h;
        struct samr_domain_state *d_state;
-       int i;
+       int i, total;
        NTSTATUS status = NT_STATUS_OK;
-       struct samr_String *names;
+       struct lsa_String *names;
        uint32_t *ids;
 
        ZERO_STRUCT(r->out.names);
@@ -1351,33 +1381,44 @@ static NTSTATUS samr_LookupRids(struct dcesrv_call_state *dce_call, TALLOC_CTX *
        if (r->in.num_rids == 0)
                return NT_STATUS_OK;
 
-       names = talloc_array(mem_ctx, struct samr_String, r->in.num_rids);
+       names = talloc_array(mem_ctx, struct lsa_String, r->in.num_rids);
        ids = talloc_array(mem_ctx, uint32_t, r->in.num_rids);
 
        if ((names == NULL) || (ids == NULL))
                return NT_STATUS_NO_MEMORY;
 
+       total = 0;
+
        for (i=0; i<r->in.num_rids; i++) {
                struct ldb_message **res;
                int count;
                const char * const attrs[] = {  "sAMAccountType",
                                                "sAMAccountName", NULL };
                uint32_t atype;
+               struct dom_sid *sid;
 
                ids[i] = SID_NAME_UNKNOWN;
 
-               count = samdb_search(d_state->sam_ctx, mem_ctx,
+               sid = dom_sid_add_rid(mem_ctx, d_state->domain_sid, r->in.rids[i]);
+               if (sid == NULL) {
+                       names[i].string = NULL;
+                       status = STATUS_SOME_UNMAPPED;
+                       continue;
+               }
+               
+               count = gendb_search(d_state->sam_ctx, mem_ctx,
                                     d_state->domain_dn, &res, attrs,
-                                    "(objectSid=%s-%u)", d_state->domain_sid,
-                                    r->in.rids[i]);
+                                    "(objectSid=%s)", 
+                                    ldap_encode_ndr_dom_sid(mem_ctx, sid));
                if (count != 1) {
+                       names[i].string = NULL;
                        status = STATUS_SOME_UNMAPPED;
                        continue;
                }
 
                names[i].string = samdb_result_string(res[0], "sAMAccountName",
                                                      NULL);
-               
+
                atype = samdb_result_uint(res[0], "sAMAccountType", 0);
                if (atype == 0) {
                        status = STATUS_SOME_UNMAPPED;
@@ -1411,7 +1452,8 @@ static NTSTATUS samr_OpenGroup(struct dcesrv_call_state *dce_call, TALLOC_CTX *m
        struct samr_domain_state *d_state;
        struct samr_account_state *a_state;
        struct dcesrv_handle *h;
-       const char *groupname, *sidstr;
+       const char *groupname;
+       struct dom_sid *sid;
        struct ldb_message **msgs;
        struct dcesrv_handle *g_handle;
        const char * const attrs[2] = { "sAMAccountName", NULL };
@@ -1424,29 +1466,32 @@ static NTSTATUS samr_OpenGroup(struct dcesrv_call_state *dce_call, TALLOC_CTX *m
        d_state = h->data;
 
        /* form the group SID */
-       sidstr = talloc_asprintf(mem_ctx, "%s-%u", d_state->domain_sid, r->in.rid);
-       if (!sidstr) {
+       sid = dom_sid_add_rid(mem_ctx, d_state->domain_sid, r->in.rid);
+       if (!sid) {
                return NT_STATUS_NO_MEMORY;
        }
 
        /* search for the group record */
-       ret = samdb_search(d_state->sam_ctx,
+       ret = gendb_search(d_state->sam_ctx,
                           mem_ctx, d_state->domain_dn, &msgs, attrs,
                           "(&(objectSid=%s)(objectclass=group)"
                           "(grouptype=%s))",
-                          sidstr, ldb_hexstr(mem_ctx,
-                                             GTYPE_SECURITY_GLOBAL_GROUP));
+                          ldap_encode_ndr_dom_sid(mem_ctx, sid),
+                          ldb_hexstr(mem_ctx,
+                                     GTYPE_SECURITY_GLOBAL_GROUP));
        if (ret == 0) {
                return NT_STATUS_NO_SUCH_GROUP;
        }
        if (ret != 1) {
-               DEBUG(0,("Found %d records matching sid %s\n", ret, sidstr));
+               DEBUG(0,("Found %d records matching sid %s\n", 
+                        ret, dom_sid_string(mem_ctx, sid)));
                return NT_STATUS_INTERNAL_DB_CORRUPTION;
        }
 
        groupname = samdb_result_string(msgs[0], "sAMAccountName", NULL);
        if (groupname == NULL) {
-               DEBUG(0,("sAMAccountName field missing for sid %s\n", sidstr));
+               DEBUG(0,("sAMAccountName field missing for sid %s\n", 
+                        dom_sid_string(mem_ctx, sid)));
                return NT_STATUS_INTERNAL_DB_CORRUPTION;
        }
 
@@ -1458,7 +1503,7 @@ static NTSTATUS samr_OpenGroup(struct dcesrv_call_state *dce_call, TALLOC_CTX *m
        a_state->access_mask = r->in.access_mask;
        a_state->domain_state = talloc_reference(a_state, d_state);
        a_state->account_dn = talloc_steal(a_state, msgs[0]->dn);
-       a_state->account_sid = talloc_steal(a_state, sidstr);
+       a_state->account_sid = talloc_steal(a_state, sid);
        a_state->account_name = talloc_strdup(a_state, groupname);
        if (!a_state->account_name) {
                return NT_STATUS_NO_MEMORY;
@@ -1546,8 +1591,8 @@ static NTSTATUS samr_QueryGroupInfo(struct dcesrv_call_state *dce_call, TALLOC_C
        a_state = h->data;
 
        /* pull all the group attributes */
-       ret = samdb_search(a_state->sam_ctx, mem_ctx, NULL, &res, attrs,
-                          "dn=%s", a_state->account_dn);
+       ret = gendb_search_dn(a_state->sam_ctx, mem_ctx,
+                             a_state->account_dn, &res, attrs);
        if (ret != 1) {
                return NT_STATUS_INTERNAL_DB_CORRUPTION;
        }
@@ -1606,7 +1651,7 @@ static NTSTATUS samr_SetGroupInfo(struct dcesrv_call_state *dce_call, TALLOC_CTX
                return NT_STATUS_NO_MEMORY;
        }       
 
-       msg->dn = talloc_strdup(mem_ctx, a_state->account_dn);
+       msg->dn = ldb_dn_copy(mem_ctx, a_state->account_dn);
        if (!msg->dn) {
                return NT_STATUS_NO_MEMORY;
        }
@@ -1648,10 +1693,10 @@ static NTSTATUS samr_AddGroupMember(struct dcesrv_call_state *dce_call, TALLOC_C
        struct samr_account_state *a_state;
        struct samr_domain_state *d_state;
        struct ldb_message *mod;
-       char *membersidstr;
+       struct dom_sid *membersid;
        const char *memberdn;
        struct ldb_message **msgs;
-       const char * const attrs[2] = { "dn", NULL };
+       const char * const attrs[2] = { "distinguishedName", NULL };
        int ret;
 
        DCESRV_PULL_HANDLE(h, r->in.group_handle, SAMR_HANDLE_GROUP);
@@ -1659,16 +1704,15 @@ static NTSTATUS samr_AddGroupMember(struct dcesrv_call_state *dce_call, TALLOC_C
        a_state = h->data;
        d_state = a_state->domain_state;
 
-       membersidstr = talloc_asprintf(mem_ctx, "%s-%u", d_state->domain_sid,
-                                      r->in.rid);
-       if (membersidstr == NULL)
+       membersid = dom_sid_add_rid(mem_ctx, d_state->domain_sid, r->in.rid);
+       if (membersid == NULL)
                return NT_STATUS_NO_MEMORY;
 
        /* In native mode, AD can also nest domain groups. Not sure yet
         * whether this is also available via RPC. */
-       ret = samdb_search(d_state->sam_ctx, mem_ctx, d_state->domain_dn,
+       ret = gendb_search(d_state->sam_ctx, mem_ctx, d_state->domain_dn,
                           &msgs, attrs, "(&(objectSid=%s)(objectclass=user))",
-                          membersidstr);
+                          ldap_encode_ndr_dom_sid(mem_ctx, membersid));
 
        if (ret == 0)
                return NT_STATUS_NO_SUCH_USER;
@@ -1676,7 +1720,7 @@ static NTSTATUS samr_AddGroupMember(struct dcesrv_call_state *dce_call, TALLOC_C
        if (ret > 1)
                return NT_STATUS_INTERNAL_DB_CORRUPTION;
 
-       memberdn = samdb_result_string(msgs[0], "dn", NULL);
+       memberdn = samdb_result_string(msgs[0], "distinguishedName", NULL);
 
        if (memberdn == NULL)
                return NT_STATUS_INTERNAL_DB_CORRUPTION;
@@ -1736,10 +1780,10 @@ static NTSTATUS samr_DeleteGroupMember(struct dcesrv_call_state *dce_call, TALLO
        struct samr_account_state *a_state;
        struct samr_domain_state *d_state;
        struct ldb_message *mod;
-       char *membersidstr;
+       struct dom_sid *membersid;
        const char *memberdn;
        struct ldb_message **msgs;
-       const char * const attrs[2] = { "dn", NULL };
+       const char * const attrs[2] = { "distinguishedName", NULL };
        int ret;
 
        DCESRV_PULL_HANDLE(h, r->in.group_handle, SAMR_HANDLE_GROUP);
@@ -1747,16 +1791,15 @@ static NTSTATUS samr_DeleteGroupMember(struct dcesrv_call_state *dce_call, TALLO
        a_state = h->data;
        d_state = a_state->domain_state;
 
-       membersidstr = talloc_asprintf(mem_ctx, "%s-%u", d_state->domain_sid,
-                                      r->in.rid);
-       if (membersidstr == NULL)
+       membersid = dom_sid_add_rid(mem_ctx, d_state->domain_sid, r->in.rid);
+       if (membersid == NULL)
                return NT_STATUS_NO_MEMORY;
 
        /* In native mode, AD can also nest domain groups. Not sure yet
         * whether this is also available via RPC. */
-       ret = samdb_search(d_state->sam_ctx, mem_ctx, d_state->domain_dn,
+       ret = gendb_search(d_state->sam_ctx, mem_ctx, d_state->domain_dn,
                           &msgs, attrs, "(&(objectSid=%s)(objectclass=user))",
-                          membersidstr);
+                          ldap_encode_ndr_dom_sid(mem_ctx, membersid));
 
        if (ret == 0)
                return NT_STATUS_NO_SUCH_USER;
@@ -1764,7 +1807,7 @@ static NTSTATUS samr_DeleteGroupMember(struct dcesrv_call_state *dce_call, TALLO
        if (ret > 1)
                return NT_STATUS_INTERNAL_DB_CORRUPTION;
 
-       memberdn = samdb_result_string(msgs[0], "dn", NULL);
+       memberdn = samdb_result_string(msgs[0], "distinguishedName", NULL);
 
        if (memberdn == NULL)
                return NT_STATUS_INTERNAL_DB_CORRUPTION;
@@ -1791,13 +1834,13 @@ static NTSTATUS samr_DeleteGroupMember(struct dcesrv_call_state *dce_call, TALLO
   samr_QueryGroupMember 
 */
 static NTSTATUS samr_QueryGroupMember(struct dcesrv_call_state *dce_call, TALLOC_CTX *mem_ctx,
-                      struct samr_QueryGroupMember *r)
+                                     struct samr_QueryGroupMember *r)
 {
        struct dcesrv_handle *h;
        struct samr_account_state *a_state;
        struct ldb_message **res;
        struct ldb_message_element *el;
-       struct samr_ridArray *array;
+       struct samr_RidTypeArray *array;
        const char * const attrs[2] = { "member", NULL };
        int ret;
 
@@ -1806,14 +1849,14 @@ static NTSTATUS samr_QueryGroupMember(struct dcesrv_call_state *dce_call, TALLOC
        a_state = h->data;
 
        /* pull the member attribute */
-       ret = samdb_search(a_state->sam_ctx, mem_ctx, NULL, &res, attrs,
-                          "dn=%s", a_state->account_dn);
+       ret = gendb_search_dn(a_state->sam_ctx, mem_ctx,
+                             a_state->account_dn, &res, attrs);
 
        if (ret != 1) {
                return NT_STATUS_INTERNAL_DB_CORRUPTION;
        }
 
-       array = talloc(mem_ctx, struct samr_ridArray);
+       array = talloc(mem_ctx, struct samr_RidTypeArray);
 
        if (array == NULL)
                return NT_STATUS_NO_MEMORY;
@@ -1827,22 +1870,22 @@ static NTSTATUS samr_QueryGroupMember(struct dcesrv_call_state *dce_call, TALLOC
 
                array->count = el->num_values;
 
-               array->rids = talloc_array(mem_ctx, uint32,
+               array->rids = talloc_array(mem_ctx, uint32_t,
                                             el->num_values);
                if (array->rids == NULL)
                        return NT_STATUS_NO_MEMORY;
 
-               array->unknown = talloc_array(mem_ctx, uint32,
-                                               el->num_values);
-               if (array->unknown == NULL)
+               array->types = talloc_array(mem_ctx, uint32_t,
+                                           el->num_values);
+               if (array->types == NULL)
                        return NT_STATUS_NO_MEMORY;
 
                for (i=0; i<el->num_values; i++) {
                        struct ldb_message **res2;
                        const char * const attrs2[2] = { "objectSid", NULL };
-                       ret = samdb_search(a_state->sam_ctx, mem_ctx, NULL,
-                                          &res2, attrs2, "dn=%s",
-                                          (char *)el->values[i].data);
+                       ret = gendb_search_dn(a_state->sam_ctx, mem_ctx,
+                                          ldb_dn_explode(mem_ctx, el->values[i].data),
+                                          &res2, attrs2);
                        if (ret != 1)
                                return NT_STATUS_INTERNAL_DB_CORRUPTION;
 
@@ -1853,7 +1896,7 @@ static NTSTATUS samr_QueryGroupMember(struct dcesrv_call_state *dce_call, TALLOC
                        if (array->rids[i] == 0)
                                return NT_STATUS_INTERNAL_DB_CORRUPTION;
 
-                       array->unknown[i] = 7; /* Not sure what this is.. */
+                       array->types[i] = 7; /* RID type of some kind, not sure what the value means. */
                }
        }
 
@@ -1882,7 +1925,8 @@ static NTSTATUS samr_OpenAlias(struct dcesrv_call_state *dce_call, TALLOC_CTX *m
        struct samr_domain_state *d_state;
        struct samr_account_state *a_state;
        struct dcesrv_handle *h;
-       const char *aliasname, *sidstr;
+       const char *alias_name;
+       struct dom_sid *sid;
        struct ldb_message **msgs;
        struct dcesrv_handle *g_handle;
        const char * const attrs[2] = { "sAMAccountName", NULL };
@@ -1895,17 +1939,16 @@ static NTSTATUS samr_OpenAlias(struct dcesrv_call_state *dce_call, TALLOC_CTX *m
        d_state = h->data;
 
        /* form the alias SID */
-       sidstr = talloc_asprintf(mem_ctx, "%s-%u", d_state->domain_sid,
-                                r->in.rid);
-       if (sidstr == NULL)
+       sid = dom_sid_add_rid(mem_ctx, d_state->domain_sid, r->in.rid);
+       if (sid == NULL)
                return NT_STATUS_NO_MEMORY;
 
        /* search for the group record */
-       ret = samdb_search(d_state->sam_ctx,
+       ret = gendb_search(d_state->sam_ctx,
                           mem_ctx, d_state->domain_dn, &msgs, attrs,
                           "(&(objectSid=%s)(objectclass=group)"
                           "(|(grouptype=%s)(grouptype=%s)))",
-                          sidstr,
+                          ldap_encode_ndr_dom_sid(mem_ctx, sid),
                           ldb_hexstr(mem_ctx,
                                      GTYPE_SECURITY_BUILTIN_LOCAL_GROUP),
                           ldb_hexstr(mem_ctx,
@@ -1914,13 +1957,15 @@ static NTSTATUS samr_OpenAlias(struct dcesrv_call_state *dce_call, TALLOC_CTX *m
                return NT_STATUS_NO_SUCH_ALIAS;
        }
        if (ret != 1) {
-               DEBUG(0,("Found %d records matching sid %s\n", ret, sidstr));
+               DEBUG(0,("Found %d records matching sid %s\n", 
+                        ret, dom_sid_string(mem_ctx, sid)));
                return NT_STATUS_INTERNAL_DB_CORRUPTION;
        }
 
-       aliasname = samdb_result_string(msgs[0], "sAMAccountName", NULL);
-       if (aliasname == NULL) {
-               DEBUG(0,("sAMAccountName field missing for sid %s\n", sidstr));
+       alias_name = samdb_result_string(msgs[0], "sAMAccountName", NULL);
+       if (alias_name == NULL) {
+               DEBUG(0,("sAMAccountName field missing for sid %s\n", 
+                        dom_sid_string(mem_ctx, sid)));
                return NT_STATUS_INTERNAL_DB_CORRUPTION;
        }
 
@@ -1932,8 +1977,8 @@ static NTSTATUS samr_OpenAlias(struct dcesrv_call_state *dce_call, TALLOC_CTX *m
        a_state->access_mask = r->in.access_mask;
        a_state->domain_state = talloc_reference(a_state, d_state);
        a_state->account_dn = talloc_steal(a_state, msgs[0]->dn);
-       a_state->account_sid = talloc_steal(a_state, sidstr);
-       a_state->account_name = talloc_strdup(a_state, aliasname);
+       a_state->account_sid = talloc_steal(a_state, sid);
+       a_state->account_name = talloc_strdup(a_state, alias_name);
        if (!a_state->account_name) {
                return NT_STATUS_NO_MEMORY;
        }
@@ -1972,8 +2017,8 @@ static NTSTATUS samr_QueryAliasInfo(struct dcesrv_call_state *dce_call, TALLOC_C
        a_state = h->data;
 
        /* pull all the alias attributes */
-       ret = samdb_search(a_state->sam_ctx, mem_ctx, NULL, &res, attrs,
-                          "dn=%s", a_state->account_dn);
+       ret = gendb_search_dn(a_state->sam_ctx, mem_ctx,
+                             a_state->account_dn ,&res, attrs);
        if (ret != 1) {
                return NT_STATUS_INTERNAL_DB_CORRUPTION;
        }
@@ -2027,7 +2072,7 @@ static NTSTATUS samr_SetAliasInfo(struct dcesrv_call_state *dce_call, TALLOC_CTX
                return NT_STATUS_NO_MEMORY;
        }
 
-       msg->dn = talloc_strdup(mem_ctx, a_state->account_dn);
+       msg->dn = ldb_dn_copy(mem_ctx, a_state->account_dn);
        if (!msg->dn) {
                return NT_STATUS_NO_MEMORY;
        }
@@ -2062,7 +2107,24 @@ static NTSTATUS samr_SetAliasInfo(struct dcesrv_call_state *dce_call, TALLOC_CTX
 static NTSTATUS samr_DeleteDomAlias(struct dcesrv_call_state *dce_call, TALLOC_CTX *mem_ctx,
                       struct samr_DeleteDomAlias *r)
 {
-       DCESRV_FAULT(DCERPC_FAULT_OP_RNG_ERROR);
+       struct dcesrv_handle *h;
+       struct samr_account_state *a_state;
+       int ret;
+
+        *r->out.alias_handle = *r->in.alias_handle;
+
+       DCESRV_PULL_HANDLE(h, r->in.alias_handle, SAMR_HANDLE_ALIAS);
+
+       a_state = h->data;
+
+       ret = samdb_delete(a_state->sam_ctx, mem_ctx, a_state->account_dn);
+       if (ret != 0) {
+               return NT_STATUS_UNSUCCESSFUL;
+       }
+
+       ZERO_STRUCTP(r->out.alias_handle);
+
+       return NT_STATUS_OK;
 }
 
 
@@ -2075,11 +2137,10 @@ static NTSTATUS samr_AddAliasMember(struct dcesrv_call_state *dce_call, TALLOC_C
        struct dcesrv_handle *h;
        struct samr_account_state *a_state;
        struct samr_domain_state *d_state;
-       const char *sidstr;
        struct ldb_message *mod;
        struct ldb_message **msgs;
-       const char * const attrs[2] = { "dn", NULL };
-       const char *memberdn = NULL;
+       const char * const attrs[2] = { "distinguishedName", NULL };
+       struct ldb_dn *memberdn = NULL;
        int ret;
 
        DCESRV_PULL_HANDLE(h, r->in.alias_handle, SAMR_HANDLE_ALIAS);
@@ -2087,28 +2148,27 @@ static NTSTATUS samr_AddAliasMember(struct dcesrv_call_state *dce_call, TALLOC_C
        a_state = h->data;
        d_state = a_state->domain_state;
 
-       sidstr = dom_sid_string(mem_ctx, r->in.sid);
-       if (sidstr == NULL)
-               return NT_STATUS_INVALID_PARAMETER;
-
-       ret = samdb_search(d_state->sam_ctx, mem_ctx, NULL,
-                          &msgs, attrs, "(objectsid=%s)", sidstr);
+       ret = gendb_search(d_state->sam_ctx, mem_ctx, NULL,
+                          &msgs, attrs, "(objectsid=%s)", 
+                          ldap_encode_ndr_dom_sid(mem_ctx, r->in.sid));
 
        if (ret == 1) {
-               memberdn = ldb_msg_find_string(msgs[0], "dn", NULL);
+               memberdn = ldb_dn_explode(mem_ctx, ldb_msg_find_string(msgs[0], "distinguishedName", NULL));
        } else  if (ret > 1) {
-               DEBUG(0,("Found %d records matching sid %s\n", ret, sidstr));
+               DEBUG(0,("Found %d records matching sid %s\n", 
+                        ret, dom_sid_string(mem_ctx, r->in.sid)));
                return NT_STATUS_INTERNAL_DB_CORRUPTION;
        } else if (ret == 0) {
                struct ldb_message *msg;
-               struct GUID guid;
-               const char *guidstr, *basedn;
+               struct ldb_dn *basedn;
+               const char *sidstr;
+
+               sidstr = dom_sid_string(mem_ctx, r->in.sid);
+               NT_STATUS_HAVE_NO_MEMORY(sidstr);
 
                /* We might have to create a ForeignSecurityPrincipal, but
                 * only if it's not our own domain */
-               if (dom_sid_in_domain(dom_sid_parse_talloc(mem_ctx,
-                                                          d_state->domain_sid),
-                                     r->in.sid))
+               if (dom_sid_in_domain(d_state->domain_sid, r->in.sid))
                        return NT_STATUS_OBJECT_NAME_NOT_FOUND;
 
                msg = ldb_msg_new(mem_ctx);
@@ -2116,34 +2176,14 @@ static NTSTATUS samr_AddAliasMember(struct dcesrv_call_state *dce_call, TALLOC_C
                        return NT_STATUS_NO_MEMORY;
                }
 
-               /* pull in all the template attributes */
-               ret = samdb_copy_template(d_state->sam_ctx, mem_ctx, msg, 
-                                         "(&(name=TemplateForeignSecurityPrincipal)"
-                                         "(objectclass=foreignSecurityPrincipalTemplate))");
-               if (ret != 0) {
-                       DEBUG(0,("Failed to load "
-                                "TemplateForeignSecurityPrincipal "
-                                "from samdb\n"));
-                       return NT_STATUS_INTERNAL_DB_CORRUPTION;
-               }
-
-               /* a new GUID */
-               guid = GUID_random();
-               guidstr = GUID_string(mem_ctx, &guid);
-               if (!guidstr) {
-                       return NT_STATUS_NO_MEMORY;
-               }
-
                /* TODO: Hmmm. This feels wrong. How do I find the base dn to
                 * put the ForeignSecurityPrincipals? d_state->domain_dn does
                 * not work, this is wrong for the Builtin domain, there's no
                 * cn=For...,cn=Builtin,dc={BASEDN}.  -- vl
                 */
 
-               basedn = samdb_search_string(d_state->sam_ctx, mem_ctx, NULL,
-                                            "dn",
-                                            "(&(objectClass=container)"
-                                            "(cn=ForeignSecurityPrincipals))");
+               basedn = samdb_search_dn(d_state->sam_ctx, mem_ctx, NULL,
+                                        "(&(objectClass=container)(cn=ForeignSecurityPrincipals))");
 
                if (basedn == NULL) {
                        DEBUG(0, ("Failed to find DN for "
@@ -2152,27 +2192,21 @@ static NTSTATUS samr_AddAliasMember(struct dcesrv_call_state *dce_call, TALLOC_C
                }
 
                /* add core elements to the ldb_message for the alias */
-               msg->dn = talloc_asprintf(mem_ctx, "CN=%s,%s", sidstr, basedn);
+               msg->dn = ldb_dn_build_child(mem_ctx, "CN", sidstr, basedn);
                if (msg->dn == NULL)
                        return NT_STATUS_NO_MEMORY;
 
                memberdn = msg->dn;
 
-               samdb_msg_add_string(d_state->sam_ctx, mem_ctx, msg,
-                                    "name", sidstr);
                samdb_msg_add_string(d_state->sam_ctx, mem_ctx, msg,
                                     "objectClass",
                                     "foreignSecurityPrincipal");
-               samdb_msg_add_string(d_state->sam_ctx, mem_ctx, msg,
-                                    "objectSid", sidstr);
-               samdb_msg_add_string(d_state->sam_ctx, mem_ctx, msg,
-                                    "objectGUID", guidstr);
-               
+
                /* create the alias */
                ret = samdb_add(d_state->sam_ctx, mem_ctx, msg);
                if (ret != 0) {
                        DEBUG(0,("Failed to create foreignSecurityPrincipal "
-                                "record %s\n", msg->dn));
+                                "record %s\n", ldb_dn_linearize(mem_ctx, msg->dn)));
                        return NT_STATUS_INTERNAL_DB_CORRUPTION;
                }
        } else {
@@ -2192,7 +2226,7 @@ static NTSTATUS samr_AddAliasMember(struct dcesrv_call_state *dce_call, TALLOC_C
        mod->dn = talloc_reference(mem_ctx, a_state->account_dn);
 
        if (samdb_msg_add_addval(d_state->sam_ctx, mem_ctx, mod, "member",
-                                memberdn) != 0)
+                                ldb_dn_linearize(mem_ctx, memberdn)) != 0)
                return NT_STATUS_UNSUCCESSFUL;
 
        if (samdb_modify(a_state->sam_ctx, mem_ctx, mod) != 0)
@@ -2211,7 +2245,6 @@ static NTSTATUS samr_DeleteAliasMember(struct dcesrv_call_state *dce_call, TALLO
        struct dcesrv_handle *h;
        struct samr_account_state *a_state;
        struct samr_domain_state *d_state;
-       const char *sidstr;
        struct ldb_message *mod;
        const char *memberdn;
 
@@ -2220,12 +2253,9 @@ static NTSTATUS samr_DeleteAliasMember(struct dcesrv_call_state *dce_call, TALLO
        a_state = h->data;
        d_state = a_state->domain_state;
 
-       sidstr = dom_sid_string(mem_ctx, r->in.sid);
-       if (sidstr == NULL)
-               return NT_STATUS_INVALID_PARAMETER;
-
        memberdn = samdb_search_string(d_state->sam_ctx, mem_ctx, NULL,
-                                      "dn", "(objectSid=%s)", sidstr);
+                                      "distinguishedName", "(objectSid=%s)", 
+                                      ldap_encode_ndr_dom_sid(mem_ctx, r->in.sid));
 
        if (memberdn == NULL)
                return NT_STATUS_OBJECT_NAME_NOT_FOUND;
@@ -2268,8 +2298,8 @@ static NTSTATUS samr_GetMembersInAlias(struct dcesrv_call_state *dce_call, TALLO
        a_state = h->data;
        d_state = a_state->domain_state;
 
-       ret = samdb_search(d_state->sam_ctx, mem_ctx, NULL, &msgs, attrs,
-                          "dn=%s", a_state->account_dn);
+       ret = gendb_search_dn(d_state->sam_ctx, mem_ctx,
+                             a_state->account_dn, &msgs, attrs);
 
        if (ret != 1)
                return NT_STATUS_INTERNAL_DB_CORRUPTION;
@@ -2291,9 +2321,9 @@ static NTSTATUS samr_GetMembersInAlias(struct dcesrv_call_state *dce_call, TALLO
                for (i=0; i<el->num_values; i++) {
                        struct ldb_message **msgs2;
                        const char * const attrs2[2] = { "objectSid", NULL };
-                       ret = samdb_search(a_state->sam_ctx, mem_ctx, NULL,
-                                          &msgs2, attrs2, "dn=%s",
-                                          (char *)el->values[i].data);
+                       ret = gendb_search_dn(a_state->sam_ctx, mem_ctx,
+                                          ldb_dn_explode(mem_ctx, el->values[i].data),
+                                          &msgs2, attrs2);
                        if (ret != 1)
                                return NT_STATUS_INTERNAL_DB_CORRUPTION;
 
@@ -2319,7 +2349,8 @@ static NTSTATUS samr_OpenUser(struct dcesrv_call_state *dce_call, TALLOC_CTX *me
        struct samr_domain_state *d_state;
        struct samr_account_state *a_state;
        struct dcesrv_handle *h;
-       const char *account_name, *sidstr;
+       const char *account_name;
+       struct dom_sid *sid;
        struct ldb_message **msgs;
        struct dcesrv_handle *u_handle;
        const char * const attrs[2] = { "sAMAccountName", NULL };
@@ -2332,27 +2363,29 @@ static NTSTATUS samr_OpenUser(struct dcesrv_call_state *dce_call, TALLOC_CTX *me
        d_state = h->data;
 
        /* form the users SID */
-       sidstr = talloc_asprintf(mem_ctx, "%s-%u", d_state->domain_sid, r->in.rid);
-       if (!sidstr) {
+       sid = dom_sid_add_rid(mem_ctx, d_state->domain_sid, r->in.rid);
+       if (!sid) {
                return NT_STATUS_NO_MEMORY;
        }
 
        /* search for the user record */
-       ret = samdb_search(d_state->sam_ctx,
+       ret = gendb_search(d_state->sam_ctx,
                           mem_ctx, d_state->domain_dn, &msgs, attrs,
                           "(&(objectSid=%s)(objectclass=user))", 
-                          sidstr);
+                          ldap_encode_ndr_dom_sid(mem_ctx, sid));
        if (ret == 0) {
                return NT_STATUS_NO_SUCH_USER;
        }
        if (ret != 1) {
-               DEBUG(0,("Found %d records matching sid %s\n", ret, sidstr));
+               DEBUG(0,("Found %d records matching sid %s\n", ret, 
+                        dom_sid_string(mem_ctx, sid)));
                return NT_STATUS_INTERNAL_DB_CORRUPTION;
        }
 
        account_name = samdb_result_string(msgs[0], "sAMAccountName", NULL);
        if (account_name == NULL) {
-               DEBUG(0,("sAMAccountName field missing for sid %s\n", sidstr));
+               DEBUG(0,("sAMAccountName field missing for sid %s\n", 
+                        dom_sid_string(mem_ctx, sid)));
                return NT_STATUS_INTERNAL_DB_CORRUPTION;
        }
 
@@ -2364,7 +2397,7 @@ static NTSTATUS samr_OpenUser(struct dcesrv_call_state *dce_call, TALLOC_CTX *me
        a_state->access_mask = r->in.access_mask;
        a_state->domain_state = talloc_reference(a_state, d_state);
        a_state->account_dn = talloc_steal(a_state, msgs[0]->dn);
-       a_state->account_sid = talloc_steal(a_state, sidstr);
+       a_state->account_sid = talloc_steal(a_state, sid);
        a_state->account_name = talloc_strdup(a_state, account_name);
        if (!a_state->account_name) {
                return NT_STATUS_NO_MEMORY;
@@ -2430,8 +2463,8 @@ static NTSTATUS samr_QueryUserInfo(struct dcesrv_call_state *dce_call, TALLOC_CT
        a_state = h->data;
 
        /* pull all the user attributes */
-       ret = samdb_search(a_state->sam_ctx, mem_ctx, NULL, &res, NULL,
-                          "dn=%s", a_state->account_dn);
+       ret = gendb_search_dn(a_state->sam_ctx, mem_ctx,
+                             a_state->account_dn ,&res, NULL);
        if (ret != 1) {
                return NT_STATUS_INTERNAL_DB_CORRUPTION;
        }
@@ -2634,6 +2667,10 @@ static NTSTATUS samr_SetUserInfo(struct dcesrv_call_state *dce_call, TALLOC_CTX
                SET_STRING(msg, info6.full_name.string,        "displayName");
                break;
 
+       case 7:
+               SET_STRING(msg, info7.account_name.string,     "samAccountName");
+               break;
+
        case 8:
                SET_STRING(msg, info8.full_name.string,        "displayName");
                break;
@@ -2673,7 +2710,9 @@ static NTSTATUS samr_SetUserInfo(struct dcesrv_call_state *dce_call, TALLOC_CTX
 
        case 21:
 #define IFSET(bit) if (bit & r->in.info->info21.fields_present)
-               IFSET(SAMR_FIELD_NAME)         
+               IFSET(SAMR_FIELD_ACCOUNT_NAME)         
+                       SET_STRING(msg, info21.account_name.string, "samAccountName");
+               IFSET(SAMR_FIELD_FULL_NAME)         
                        SET_STRING(msg, info21.full_name.string,    "displayName");
                IFSET(SAMR_FIELD_DESCRIPTION)  
                        SET_STRING(msg, info21.description.string,  "description");
@@ -2683,7 +2722,7 @@ static NTSTATUS samr_SetUserInfo(struct dcesrv_call_state *dce_call, TALLOC_CTX
                        SET_STRING(msg, info21.logon_script.string, "scriptPath");
                IFSET(SAMR_FIELD_PROFILE_PATH)      
                        SET_STRING(msg, info21.profile_path.string, "profilePath");
-               IFSET(SAMR_FIELD_WORKSTATION)  
+               IFSET(SAMR_FIELD_WORKSTATIONS)  
                        SET_STRING(msg, info21.workstations.string, "userWorkstations");
                IFSET(SAMR_FIELD_LOGON_HOURS)  
                        SET_LHOURS(msg, info21.logon_hours,         "logonHours");
@@ -2703,7 +2742,9 @@ static NTSTATUS samr_SetUserInfo(struct dcesrv_call_state *dce_call, TALLOC_CTX
 
        case 23:
 #define IFSET(bit) if (bit & r->in.info->info23.info.fields_present)
-               IFSET(SAMR_FIELD_NAME)         
+               IFSET(SAMR_FIELD_ACCOUNT_NAME)         
+                       SET_STRING(msg, info23.info.account_name.string, "samAccountName");
+               IFSET(SAMR_FIELD_FULL_NAME)         
                        SET_STRING(msg, info23.info.full_name.string,    "displayName");
                IFSET(SAMR_FIELD_DESCRIPTION)  
                        SET_STRING(msg, info23.info.description.string,  "description");
@@ -2713,7 +2754,7 @@ static NTSTATUS samr_SetUserInfo(struct dcesrv_call_state *dce_call, TALLOC_CTX
                        SET_STRING(msg, info23.info.logon_script.string, "scriptPath");
                IFSET(SAMR_FIELD_PROFILE_PATH)      
                        SET_STRING(msg, info23.info.profile_path.string, "profilePath");
-               IFSET(SAMR_FIELD_WORKSTATION)  
+               IFSET(SAMR_FIELD_WORKSTATIONS)  
                        SET_STRING(msg, info23.info.workstations.string, "userWorkstations");
                IFSET(SAMR_FIELD_LOGON_HOURS)  
                        SET_LHOURS(msg, info23.info.logon_hours,         "logonHours");
@@ -2755,7 +2796,9 @@ static NTSTATUS samr_SetUserInfo(struct dcesrv_call_state *dce_call, TALLOC_CTX
 
        case 25:
 #define IFSET(bit) if (bit & r->in.info->info25.info.fields_present)
-               IFSET(SAMR_FIELD_NAME)         
+               IFSET(SAMR_FIELD_ACCOUNT_NAME)         
+                       SET_STRING(msg, info25.info.account_name.string, "samAccountName");
+               IFSET(SAMR_FIELD_FULL_NAME)         
                        SET_STRING(msg, info25.info.full_name.string,    "displayName");
                IFSET(SAMR_FIELD_DESCRIPTION)  
                        SET_STRING(msg, info25.info.description.string,  "description");
@@ -2765,7 +2808,7 @@ static NTSTATUS samr_SetUserInfo(struct dcesrv_call_state *dce_call, TALLOC_CTX
                        SET_STRING(msg, info25.info.logon_script.string, "scriptPath");
                IFSET(SAMR_FIELD_PROFILE_PATH)      
                        SET_STRING(msg, info25.info.profile_path.string, "profilePath");
-               IFSET(SAMR_FIELD_WORKSTATION)  
+               IFSET(SAMR_FIELD_WORKSTATIONS)  
                        SET_STRING(msg, info25.info.workstations.string, "userWorkstations");
                IFSET(SAMR_FIELD_LOGON_HOURS)  
                        SET_LHOURS(msg, info25.info.logon_hours,         "logonHours");
@@ -2836,41 +2879,37 @@ static NTSTATUS samr_GetGroupsForUser(struct dcesrv_call_state *dce_call, TALLOC
        struct samr_account_state *a_state;
        struct samr_domain_state *d_state;
        struct ldb_message **res;
-       struct dom_sid *domain_sid;
        const char * const attrs[2] = { "objectSid", NULL };
-       struct samr_RidArray *array;
+       struct samr_RidWithAttributeArray *array;
        int count;
 
        DCESRV_PULL_HANDLE(h, r->in.user_handle, SAMR_HANDLE_USER);
 
        a_state = h->data;
        d_state = a_state->domain_state;
-       domain_sid = dom_sid_parse_talloc(mem_ctx, d_state->domain_sid);
-       if (domain_sid == NULL)
-               return NT_STATUS_NO_MEMORY;
 
        count = samdb_search_domain(a_state->sam_ctx, mem_ctx, NULL, &res,
-                                   attrs, domain_sid,
+                                   attrs, d_state->domain_sid,
                                    "(&(member=%s)(grouptype=%s)(objectclass=group))",
-                                   a_state->account_dn,
+                                   ldb_dn_linearize(mem_ctx, a_state->account_dn),
                                    ldb_hexstr(mem_ctx,
                                               GTYPE_SECURITY_GLOBAL_GROUP));
        if (count < 0)
                return NT_STATUS_INTERNAL_DB_CORRUPTION;
 
-       array = talloc(mem_ctx, struct samr_RidArray);
+       array = talloc(mem_ctx, struct samr_RidWithAttributeArray);
        if (array == NULL)
                return NT_STATUS_NO_MEMORY;
 
        array->count = 0;
-       array->rid = NULL;
+       array->rids = NULL;
 
        if (count > 0) {
                int i;
-               array->rid = talloc_array(mem_ctx, struct samr_RidType,
+               array->rids = talloc_array(mem_ctx, struct samr_RidWithAttribute,
                                            count);
 
-               if (array->rid == NULL)
+               if (array->rids == NULL)
                        return NT_STATUS_NO_MEMORY;
 
                for (i=0; i<count; i++) {
@@ -2883,9 +2922,9 @@ static NTSTATUS samr_GetGroupsForUser(struct dcesrv_call_state *dce_call, TALLOC
                                continue;
                        }
 
-                       array->rid[array->count].rid =
+                       array->rids[array->count].rid =
                                group_sid->sub_auths[group_sid->num_auths-1];
-                       array->rid[array->count].type = 7;
+                       array->rids[array->count].attributes = SE_GROUP_MANDATORY | SE_GROUP_ENABLED_BY_DEFAULT | SE_GROUP_ENABLED;
                        array->count += 1;
                }
        }
@@ -2908,7 +2947,6 @@ static NTSTATUS samr_QueryDisplayInfo(struct dcesrv_call_state *dce_call, TALLOC
        int ldb_cnt, count, i;
        const char * const attrs[4] = { "objectSid", "sAMAccountName",
                                        "description", NULL };
-       struct dom_sid *domain_sid;
        struct samr_DispEntryFull *entriesFull = NULL;
        struct samr_DispEntryAscii *entriesAscii = NULL;
        struct samr_DispEntryGeneral * entriesGeneral = NULL;
@@ -2942,15 +2980,11 @@ static NTSTATUS samr_QueryDisplayInfo(struct dcesrv_call_state *dce_call, TALLOC
                return NT_STATUS_INVALID_INFO_CLASS;
        }
 
-       domain_sid = dom_sid_parse_talloc(mem_ctx, d_state->domain_sid);
-       if (domain_sid == NULL)
-               return NT_STATUS_NO_MEMORY;
-
        /* search for all requested objects in this domain. This could
           possibly be cached and resumed based on resume_key */
        ldb_cnt = samdb_search_domain(d_state->sam_ctx, mem_ctx,
                                      d_state->domain_dn, &res, attrs,
-                                     domain_sid, "%s", filter);
+                                     d_state->domain_sid, "%s", filter);
        if (ldb_cnt == -1) {
                return NT_STATUS_INTERNAL_DB_CORRUPTION;
        }
@@ -2994,7 +3028,7 @@ static NTSTATUS samr_QueryDisplayInfo(struct dcesrv_call_state *dce_call, TALLOC
 
                switch(r->in.level) {
                case 1:
-                       entriesGeneral[count].idx = count;
+                       entriesGeneral[count].idx = count + 1;
                        entriesGeneral[count].rid = 
                                objectsid->sub_auths[objectsid->num_auths-1];
                        entriesGeneral[count].acct_flags =
@@ -3010,7 +3044,7 @@ static NTSTATUS samr_QueryDisplayInfo(struct dcesrv_call_state *dce_call, TALLOC
                        break;
                case 2:
                case 3:
-                       entriesFull[count].idx = count;
+                       entriesFull[count].idx = count + 1;
                        entriesFull[count].rid =
                                objectsid->sub_auths[objectsid->num_auths-1];
                        entriesFull[count].acct_flags =
@@ -3028,7 +3062,7 @@ static NTSTATUS samr_QueryDisplayInfo(struct dcesrv_call_state *dce_call, TALLOC
                        break;
                case 4:
                case 5:
-                       entriesAscii[count].idx = count;
+                       entriesAscii[count].idx = count + 1;
                        entriesAscii[count].account_name.string =
                                samdb_result_string(res[i], "sAMAccountName",
                                                    "");
@@ -3146,10 +3180,12 @@ static NTSTATUS samr_GetUserPwInfo(struct dcesrv_call_state *dce_call, TALLOC_CT
 
        a_state = h->data;
 
-       r->out.info.min_password_length = samdb_search_uint(a_state->sam_ctx, mem_ctx, 0, NULL, "minPwdLength", 
-                                                           "dn=%s", a_state->domain_state->domain_dn);
-       r->out.info.password_properties = samdb_search_uint(a_state->sam_ctx, mem_ctx, 0, NULL, "pwdProperties", 
-                                                           "dn=%s", a_state->account_dn);
+       r->out.info.min_password_length = samdb_search_uint(a_state->sam_ctx, mem_ctx, 0,
+                                                           a_state->domain_state->domain_dn, "minPwdLength", 
+                                                           NULL);
+       r->out.info.password_properties = samdb_search_uint(a_state->sam_ctx, mem_ctx, 0,
+                                                           a_state->account_dn, 
+                                                           "pwdProperties", NULL);
        return NT_STATUS_OK;
 }
 
@@ -3162,23 +3198,18 @@ static NTSTATUS samr_RemoveMemberFromForeignDomain(struct dcesrv_call_state *dce
 {
        struct dcesrv_handle *h;
        struct samr_domain_state *d_state;
-       struct dom_sid *domain_sid;
-       const char *membersid, *memberdn;
+       const char *memberdn;
        struct ldb_message **res;
-       const char * const attrs[3] = { "dn", "objectSid", NULL };
+       const char * const attrs[3] = { "distinguishedName", "objectSid", NULL };
        int i, count;
 
        DCESRV_PULL_HANDLE(h, r->in.domain_handle, SAMR_HANDLE_DOMAIN);
 
        d_state = h->data;
 
-       domain_sid = dom_sid_parse_talloc(mem_ctx, d_state->domain_sid);
-       membersid = dom_sid_string(mem_ctx, r->in.sid);
-       if ((domain_sid == NULL) || (membersid == NULL))
-               return NT_STATUS_NO_MEMORY;
-
        memberdn = samdb_search_string(d_state->sam_ctx, mem_ctx, NULL,
-                                      "dn", "(objectSid=%s)", membersid);
+                                      "distinguishedName", "(objectSid=%s)", 
+                                      ldap_encode_ndr_dom_sid(mem_ctx, r->in.sid));
        if (memberdn == NULL)
                return NT_STATUS_OBJECT_NAME_NOT_FOUND;
 
@@ -3187,7 +3218,7 @@ static NTSTATUS samr_RemoveMemberFromForeignDomain(struct dcesrv_call_state *dce
 
        count = samdb_search_domain(d_state->sam_ctx, mem_ctx,
                                    d_state->domain_dn, &res, attrs,
-                                   domain_sid,
+                                   d_state->domain_sid,
                                    "(&(member=%s)(objectClass=group)"
                                    "(|(groupType=%s)(groupType=%s)))",
                                    memberdn,
@@ -3207,9 +3238,7 @@ static NTSTATUS samr_RemoveMemberFromForeignDomain(struct dcesrv_call_state *dce
                        return NT_STATUS_NO_MEMORY;
                }
 
-               mod->dn = talloc_reference(mod,
-                                          samdb_result_string(res[i], "dn",
-                                                              NULL));
+               mod->dn = samdb_result_dn(mod, res[i], "distinguishedName", NULL);
                if (mod->dn == NULL) {
                        talloc_free(mod);
                        continue;
@@ -3342,31 +3371,30 @@ static NTSTATUS samr_GetDomPwInfo(struct dcesrv_call_state *dce_call, TALLOC_CTX
        struct ldb_message **msgs;
        int ret;
        const char * const attrs[] = {"minPwdLength", "pwdProperties", NULL };
-       void *sam_ctx;
+       struct ldb_context *sam_ctx;
 
        ZERO_STRUCT(r->out.info);
 
-       sam_ctx = samdb_connect(mem_ctx);
+       sam_ctx = samdb_connect(mem_ctx, dce_call->conn->auth_state.session_info); 
        if (sam_ctx == NULL) {
                return NT_STATUS_INVALID_SYSTEM_SERVICE;
        }
 
-       ret = samdb_search(sam_ctx, 
-                          mem_ctx, NULL, &msgs, attrs, 
-                          "(&(name=%s)(objectclass=domain))",
-                          lp_workgroup());
+       /* The domain name in this call is ignored */
+       ret = gendb_search_dn(sam_ctx, 
+                          mem_ctx, samdb_base_dn(mem_ctx), &msgs, attrs);
        if (ret <= 0) {
                return NT_STATUS_NO_SUCH_DOMAIN;
        }
        if (ret > 1) {
-               samdb_search_free(sam_ctx, mem_ctx, msgs);
+               talloc_free(msgs);
                return NT_STATUS_INTERNAL_DB_CORRUPTION;
        }
 
        r->out.info.min_password_length = samdb_result_uint(msgs[0], "minPwdLength", 0);
        r->out.info.password_properties = samdb_result_uint(msgs[0], "pwdProperties", 1);
 
-       samdb_search_free(sam_ctx, mem_ctx, msgs);
+       talloc_free(msgs);
 
        talloc_free(sam_ctx);
        return NT_STATUS_OK;