source4/dsdb/samdb/ldb_modules/rootdse.c

   1 /*
   2    Unix SMB/CIFS implementation.
   3
   4    rootDSE ldb module
   5
   6    Copyright (C) Andrew Tridgell 2005
   7    Copyright (C) Simo Sorce 2005
   8
   9    This program is free software; you can redistribute it and/or modify
  10    it under the terms of the GNU General Public License as published by
  11    the Free Software Foundation; either version 3 of the License, or
  12    (at your option) any later version.
  13
  14    This program is distributed in the hope that it will be useful,
  15    but WITHOUT ANY WARRANTY; without even the implied warranty of
  16    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  17    GNU General Public License for more details.
  18
  19    You should have received a copy of the GNU General Public License
  20    along with this program.  If not, see <http://www.gnu.org/licenses/>.
  21 */
  22
  23 #include "includes.h"
  24 #include "lib/ldb/include/ldb.h"
  25 #include "lib/ldb/include/ldb_errors.h"
  26 #include "lib/ldb/include/ldb_private.h"
  27 #include "system/time.h"
  28 #include "dsdb/samdb/samdb.h"
  29 #include "version.h"
  30
  31 struct private_data {
  32         int num_controls;
  33         char **controls;
  34         int num_partitions;
  35         struct ldb_dn **partitions;
  36 };
  37
  38 /*
  39   return 1 if a specific attribute has been requested
  40 */
  41 static int do_attribute(const char * const *attrs, const char *name)
  42 {
  43         return attrs == NULL ||
  44                 ldb_attr_in_list(attrs, name) ||
  45                 ldb_attr_in_list(attrs, "*");
  46 }
  47
  48 static int do_attribute_explicit(const char * const *attrs, const char *name)
  49 {
  50         return attrs != NULL && ldb_attr_in_list(attrs, name);
  51 }
  52
  53
  54 /*
  55   add dynamically generated attributes to rootDSE result
  56 */
  57 static int rootdse_add_dynamic(struct ldb_module *module, struct ldb_message *msg, const char * const *attrs)
  58 {
  59         struct private_data *priv = talloc_get_type(module->private_data, struct private_data);
  60         char **server_sasl;
  61         const struct dsdb_schema *schema;
  62
  63         schema = dsdb_get_schema(module->ldb);
  64
  65         msg->dn = ldb_dn_new(msg, module->ldb, NULL);
  66
  67         /* don't return the distinduishedName, cn and name attributes */
  68         ldb_msg_remove_attr(msg, "distinguishedName");
  69         ldb_msg_remove_attr(msg, "cn");
  70         ldb_msg_remove_attr(msg, "name");
  71
  72         if (do_attribute(attrs, "currentTime")) {
  73                 if (ldb_msg_add_steal_string(msg, "currentTime",
  74                                              ldb_timestring(msg, time(NULL))) != 0) {
  75                         goto failed;
  76                 }
  77         }
  78
  79         if (do_attribute(attrs, "supportedControl")) {
  80                 int i;
  81                 for (i = 0; i < priv->num_controls; i++) {
  82                         char *control = talloc_strdup(msg, priv->controls[i]);
  83                         if (!control) {
  84                                 goto failed;
  85                         }
  86                         if (ldb_msg_add_steal_string(msg, "supportedControl",
  87                                                      control) != 0) {
  88                                 goto failed;
  89                         }
  90                 }
  91         }
  92
  93         if (do_attribute(attrs, "namingContexts")) {
  94                 int i;
  95                 for (i = 0; i < priv->num_partitions; i++) {
  96                         struct ldb_dn *dn = priv->partitions[i];
  97                         if (ldb_msg_add_steal_string(msg, "namingContexts",
  98                                                      ldb_dn_alloc_linearized(msg, dn)) != 0) {
  99                                 goto failed;
 100                         }
 101                 }
 102         }
 103
 104         server_sasl = talloc_get_type(ldb_get_opaque(module->ldb, "supportedSASLMechanims"),
 105                                        char *);
 106         if (server_sasl && do_attribute(attrs, "supportedSASLMechanisms")) {
 107                 int i;
 108                 for (i = 0; server_sasl && server_sasl[i]; i++) {
 109                         char *sasl_name = talloc_strdup(msg, server_sasl[i]);
 110                         if (!sasl_name) {
 111                                 goto failed;
 112                         }
 113                         if (ldb_msg_add_steal_string(msg, "supportedSASLMechanisms",
 114                                                      sasl_name) != 0) {
 115                                 goto failed;
 116                         }
 117                 }
 118         }
 119
 120         if (do_attribute(attrs, "highestCommittedUSN")) {
 121                 uint64_t seq_num;
 122                 int ret = ldb_sequence_number(module->ldb, LDB_SEQ_HIGHEST_SEQ, &seq_num);
 123                 if (ret == LDB_SUCCESS) {
 124                         if (ldb_msg_add_fmt(msg, "highestCommittedUSN",
 125                                             "%llu", (unsigned long long)seq_num) != 0) {
 126                                 goto failed;
 127                         }
 128                 }
 129         }
 130
 131         if (schema && do_attribute_explicit(attrs, "dsSchemaAttrCount")) {
 132                 struct dsdb_attribute *cur;
 133                 uint32_t n = 0;
 134
 135                 for (cur = schema->attributes; cur; cur = cur->next) {
 136                         n++;
 137                 }
 138
 139                 if (ldb_msg_add_fmt(msg, "dsSchemaAttrCount",
 140                                     "%u", n) != 0) {
 141                         goto failed;
 142                 }
 143         }
 144
 145         if (schema && do_attribute_explicit(attrs, "dsSchemaClassCount")) {
 146                 struct dsdb_class *cur;
 147                 uint32_t n = 0;
 148
 149                 for (cur = schema->classes; cur; cur = cur->next) {
 150                         n++;
 151                 }
 152
 153                 if (ldb_msg_add_fmt(msg, "dsSchemaClassCount",
 154                                     "%u", n) != 0) {
 155                         goto failed;
 156                 }
 157         }
 158
 159         if (schema && do_attribute_explicit(attrs, "dsSchemaPrefixCount")) {
 160                 if (ldb_msg_add_fmt(msg, "dsSchemaPrefixCount",
 161                                     "%u", schema->num_prefixes) != 0) {
 162                         goto failed;
 163                 }
 164         }
 165
 166         if (do_attribute_explicit(attrs, "validFSMOs")) {
 167                 const struct dsdb_naming_fsmo *naming_fsmo;
 168                 const struct dsdb_pdc_fsmo *pdc_fsmo;
 169                 const char *dn_str;
 170
 171                 if (schema && schema->fsmo.we_are_master) {
 172                         dn_str = ldb_dn_get_linearized(samdb_schema_dn(module->ldb));
 173                         if (dn_str && dn_str[0]) {
 174                                 if (ldb_msg_add_fmt(msg, "validFSMOs", "%s", dn_str) != 0) {
 175                                         goto failed;
 176                                 }
 177                         }
 178                 }
 179
 180                 naming_fsmo = talloc_get_type(ldb_get_opaque(module->ldb, "dsdb_naming_fsmo"),
 181                                               struct dsdb_naming_fsmo);
 182                 if (naming_fsmo && naming_fsmo->we_are_master) {
 183                         dn_str = ldb_dn_get_linearized(samdb_partitions_dn(module->ldb, msg));
 184                         if (dn_str && dn_str[0]) {
 185                                 if (ldb_msg_add_fmt(msg, "validFSMOs", "%s", dn_str) != 0) {
 186                                         goto failed;
 187                                 }
 188                         }
 189                 }
 190
 191                 pdc_fsmo = talloc_get_type(ldb_get_opaque(module->ldb, "dsdb_pdc_fsmo"),
 192                                            struct dsdb_pdc_fsmo);
 193                 if (pdc_fsmo && pdc_fsmo->we_are_master) {
 194                         dn_str = ldb_dn_get_linearized(samdb_base_dn(module->ldb));
 195                         if (dn_str && dn_str[0]) {
 196                                 if (ldb_msg_add_fmt(msg, "validFSMOs", "%s", dn_str) != 0) {
 197                                         goto failed;
 198                                 }
 199                         }
 200                 }
 201         }
 202
 203         if (schema && do_attribute_explicit(attrs, "vendorVersion")) {
 204                 if (ldb_msg_add_fmt(msg, "vendorVersion",
 205                                     "%s", SAMBA_VERSION_STRING) != 0) {
 206                         goto failed;
 207                 }
 208         }
 209
 210         /* TODO: lots more dynamic attributes should be added here */
 211
 212         return LDB_SUCCESS;
 213
 214 failed:
 215         return LDB_ERR_OPERATIONS_ERROR;
 216 }
 217
 218 /*
 219   handle search requests
 220 */
 221
 222 struct rootdse_context {
 223         struct ldb_module *module;
 224         void *up_context;
 225         int (*up_callback)(struct ldb_context *, void *, struct ldb_reply *);
 226
 227         const char * const * attrs;
 228 };
 229
 230 static int rootdse_callback(struct ldb_context *ldb, void *context, struct ldb_reply *ares)
 231 {
 232         struct rootdse_context *ac;
 233
 234         ac = talloc_get_type(context, struct rootdse_context);
 235
 236         if (ares->type == LDB_REPLY_ENTRY) {
 237                 /*
 238                  * if the client explicit asks for the 'netlogon' attribute
 239                  * the reply_entry needs to be skipped
 240                  */
 241                 if (ac->attrs && ldb_attr_in_list(ac->attrs, "netlogon")) {
 242                         talloc_free(ares);
 243                         return LDB_SUCCESS;
 244                 }
 245
 246                 /* for each record returned post-process to add any dynamic
 247                    attributes that have been asked for */
 248                 if (rootdse_add_dynamic(ac->module, ares->message, ac->attrs) != LDB_SUCCESS) {
 249                         goto error;
 250                 }
 251         }
 252
 253         return ac->up_callback(ldb, ac->up_context, ares);
 254
 255 error:
 256         talloc_free(ares);
 257         return LDB_ERR_OPERATIONS_ERROR;
 258 }
 259
 260 static int rootdse_search(struct ldb_module *module, struct ldb_request *req)
 261 {
 262         struct rootdse_context *ac;
 263         struct ldb_request *down_req;
 264         int ret;
 265
 266         /* see if its for the rootDSE - only a base search on the "" DN qualifies */
 267         if (req->op.search.scope != LDB_SCOPE_BASE ||
 268             ( ! ldb_dn_is_null(req->op.search.base))) {
 269                 /* Otherwise, pass down to the rest of the stack */
 270                 return ldb_next_request(module, req);
 271         }
 272
 273         ac = talloc(req, struct rootdse_context);
 274         if (ac == NULL) {
 275                 return LDB_ERR_OPERATIONS_ERROR;
 276         }
 277
 278         ac->module = module;
 279         ac->up_context = req->context;
 280         ac->up_callback = req->callback;
 281         ac->attrs = req->op.search.attrs;
 282
 283         down_req = talloc_zero(req, struct ldb_request);
 284         if (down_req == NULL) {
 285                 return LDB_ERR_OPERATIONS_ERROR;
 286         }
 287
 288         down_req->operation = req->operation;
 289         /* in our db we store the rootDSE with a DN of @ROOTDSE */
 290         down_req->op.search.base = ldb_dn_new(down_req, module->ldb, "@ROOTDSE");
 291         down_req->op.search.scope = LDB_SCOPE_BASE;
 292         down_req->op.search.tree = ldb_parse_tree(down_req, NULL);
 293         if (down_req->op.search.base == NULL || down_req->op.search.tree == NULL) {
 294                 ldb_oom(module->ldb);
 295                 talloc_free(down_req);
 296                 return LDB_ERR_OPERATIONS_ERROR;
 297         }
 298         down_req->op.search.attrs = req->op.search.attrs;
 299         down_req->controls = req->controls;
 300
 301         down_req->context = ac;
 302         down_req->callback = rootdse_callback;
 303         ldb_set_timeout_from_prev_req(module->ldb, req, down_req);
 304
 305         /* perform the search */
 306         ret = ldb_next_request(module, down_req);
 307
 308         /* do not free down_req as the call results may be linked to it,
 309          * it will be freed when the upper level request get freed */
 310         if (ret == LDB_SUCCESS) {
 311                 req->handle = down_req->handle;
 312         }
 313
 314         return ret;
 315 }
 316
 317 static int rootdse_register_control(struct ldb_module *module, struct ldb_request *req)
 318 {
 319         struct private_data *priv = talloc_get_type(module->private_data, struct private_data);
 320         char **list;
 321
 322         list = talloc_realloc(priv, priv->controls, char *, priv->num_controls + 1);
 323         if (!list) {
 324                 return LDB_ERR_OPERATIONS_ERROR;
 325         }
 326
 327         list[priv->num_controls] = talloc_strdup(list, req->op.reg_control.oid);
 328         if (!list[priv->num_controls]) {
 329                 return LDB_ERR_OPERATIONS_ERROR;
 330         }
 331
 332         priv->num_controls += 1;
 333         priv->controls = list;
 334
 335         return LDB_SUCCESS;
 336 }
 337
 338 static int rootdse_register_partition(struct ldb_module *module, struct ldb_request *req)
 339 {
 340         struct private_data *priv = talloc_get_type(module->private_data, struct private_data);
 341         struct ldb_dn **list;
 342
 343         list = talloc_realloc(priv, priv->partitions, struct ldb_dn *, priv->num_partitions + 1);
 344         if (!list) {
 345                 return LDB_ERR_OPERATIONS_ERROR;
 346         }
 347
 348         list[priv->num_partitions] = ldb_dn_copy(list, req->op.reg_partition.dn);
 349         if (!list[priv->num_partitions]) {
 350                 return LDB_ERR_OPERATIONS_ERROR;
 351         }
 352
 353         priv->num_partitions += 1;
 354         priv->partitions = list;
 355
 356         return LDB_SUCCESS;
 357 }
 358
 359
 360 static int rootdse_request(struct ldb_module *module, struct ldb_request *req)
 361 {
 362         switch (req->operation) {
 363
 364         case LDB_REQ_REGISTER_CONTROL:
 365                 return rootdse_register_control(module, req);
 366         case LDB_REQ_REGISTER_PARTITION:
 367                 return rootdse_register_partition(module, req);
 368
 369         default:
 370                 break;
 371         }
 372         return ldb_next_request(module, req);
 373 }
 374
 375 static int rootdse_init(struct ldb_module *module)
 376 {
 377         struct private_data *data;
 378
 379         data = talloc(module, struct private_data);
 380         if (data == NULL) {
 381                 return -1;
 382         }
 383
 384         data->num_controls = 0;
 385         data->controls = NULL;
 386         data->num_partitions = 0;
 387         data->partitions = NULL;
 388         module->private_data = data;
 389
 390         ldb_set_default_dns(module->ldb);
 391
 392         return ldb_next_init(module);
 393 }
 394
 395 static int rootdse_modify(struct ldb_module *module, struct ldb_request *req)
 396 {
 397         struct ldb_result *ext_res;
 398         int ret;
 399         struct ldb_dn *schema_dn;
 400         struct ldb_message_element *schemaUpdateNowAttr;
 401
 402         /*
 403                 If dn is not "" we should let it pass through
 404         */
 405         if (!ldb_dn_is_null(req->op.mod.message->dn)) {
 406                 return ldb_next_request(module, req);
 407         }
 408
 409         /*
 410                 dn is empty so check for schemaUpdateNow attribute
 411                 "The type of modification and values specified in the LDAP modify operation do not matter." MSDN
 412         */
 413         schemaUpdateNowAttr = ldb_msg_find_element(req->op.mod.message, "schemaUpdateNow");
 414         if (!schemaUpdateNowAttr) {
 415                 return LDB_ERR_OPERATIONS_ERROR;
 416         }
 417
 418         schema_dn = samdb_schema_dn(module->ldb);
 419         if (!schema_dn) {
 420                 ldb_reset_err_string(module->ldb);
 421                 ldb_debug(module->ldb, LDB_DEBUG_WARNING,
 422                           "rootdse_modify: no schema dn present: (skip ldb_extended call)\n");
 423                 return ldb_next_request(module, req);
 424         }
 425
 426         ret = ldb_extended(module->ldb, DSDB_EXTENDED_SCHEMA_UPDATE_NOW_OID, schema_dn, &ext_res);
 427         if (ret != LDB_SUCCESS) {
 428                 return LDB_ERR_OPERATIONS_ERROR;
 429         }
 430
 431         talloc_free(ext_res);
 432         return ret;
 433 }
 434
 435 _PUBLIC_ const struct ldb_module_ops ldb_rootdse_module_ops = {
 436         .name                   = "rootdse",
 437         .init_context   = rootdse_init,
 438         .search         = rootdse_search,
 439         .request                = rootdse_request,
 440         .modify         = rootdse_modify
 441 };