source/lib/registry/reg_backend_rpc.c

   1 /*
   2    Samba Unix/Linux SMB implementation
   3    RPC backend for the registry library
   4    Copyright (C) 2003-2004 Jelmer Vernooij, jelmer@samba.org
   5
   6    This program is free software; you can redistribute it and/or modify
   7    it under the terms of the GNU General Public License as published by
   8    the Free Software Foundation; either version 2 of the License, or
   9    (at your option) any later version.
  10
  11    This program is distributed in the hope that it will be useful,
  12    but WITHOUT ANY WARRANTY; without even the implied warranty of
  13    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  14    GNU General Public License for more details.
  15
  16    You should have received a copy of the GNU General Public License
  17    along with this program; if not, write to the Free Software
  18    Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.  */
  19
  20 #include "includes.h"
  21 #include "registry.h"
  22 #include "librpc/gen_ndr/ndr_winreg_c.h"
  23
  24 static struct hive_operations reg_backend_rpc;
  25
  26 /**
  27  * This is the RPC backend for the registry library.
  28  */
  29
  30 static void init_winreg_String(struct winreg_String *name, const char *s)
  31 {
  32         name->name = s;
  33 }
  34
  35
  36 #define openhive(u) static WERROR open_ ## u(struct dcerpc_pipe *p, TALLOC_CTX *mem_ctx, struct policy_handle *hnd) \
  37 { \
  38         struct winreg_Open ## u r; \
  39         NTSTATUS status; \
  40         \
  41         r.in.system_name = NULL; \
  42         r.in.access_mask = SEC_FLAG_MAXIMUM_ALLOWED; \
  43         r.out.handle = hnd;\
  44         \
  45         status = dcerpc_winreg_Open ## u(p, mem_ctx, &r); \
  46         if (NT_STATUS_IS_ERR(status)) {\
  47                 DEBUG(0,("Error executing open\n"));\
  48                 return ntstatus_to_werror(status);\
  49         }\
  50 \
  51         return r.out.result;\
  52 }
  53
  54 openhive(HKLM)
  55 openhive(HKCU)
  56 openhive(HKPD)
  57 openhive(HKU)
  58 openhive(HKCR)
  59 openhive(HKDD)
  60 openhive(HKCC)
  61
  62 struct rpc_key_data {
  63         struct policy_handle pol;
  64         int num_subkeys;
  65         int num_values;
  66         int max_valnamelen;
  67         int max_valdatalen;
  68 };
  69
  70 static struct {
  71         uint32_t hkey;
  72         WERROR (*open) (struct dcerpc_pipe *p, TALLOC_CTX *, struct policy_handle *h);
  73 } known_hives[] = {
  74 { HKEY_LOCAL_MACHINE, open_HKLM },
  75 { HKEY_CURRENT_USER, open_HKCU },
  76 { HKEY_CLASSES_ROOT, open_HKCR },
  77 { HKEY_PERFORMANCE_DATA, open_HKPD },
  78 { HKEY_USERS, open_HKU },
  79 { HKEY_DYN_DATA, open_HKDD },
  80 { HKEY_CURRENT_CONFIG, open_HKCC },
  81 { 0, NULL }
  82 };
  83
  84 static WERROR rpc_query_key(const struct registry_key *k);
  85
  86 static WERROR rpc_get_predefined_key (struct registry_context *ctx, uint32_t hkey_type, struct registry_key **k)
  87 {
  88         int n;
  89         struct registry_hive *h;
  90         struct rpc_key_data *mykeydata;
  91
  92         for(n = 0; known_hives[n].hkey; n++)
  93         {
  94                 if(known_hives[n].hkey == hkey_type) break;
  95         }
  96
  97         if(!known_hives[n].open)  {
  98                 DEBUG(1, ("No such hive %d\n", hkey_type));
  99                 return WERR_NO_MORE_ITEMS;
 100         }
 101
 102         h = talloc(ctx, struct registry_hive);
 103         h->functions = &reg_backend_rpc;
 104         h->location = NULL;
 105         h->backend_data = ctx->backend_data;
 106
 107         (*k) = h->root = talloc(h, struct registry_key);
 108         (*k)->hive = h;
 109         (*k)->backend_data = mykeydata = talloc(*k, struct rpc_key_data);
 110         mykeydata->num_values = -1;
 111         mykeydata->num_subkeys = -1;
 112         return known_hives[n].open((struct dcerpc_pipe *)ctx->backend_data, *k, &(mykeydata->pol));
 113 }
 114
 115 #if 0
 116 static WERROR rpc_key_put_rpc_data(TALLOC_CTX *mem_ctx, struct registry_key *k)
 117 {
 118     struct winreg_OpenKey r;
 119         struct rpc_key_data *mykeydata;
 120
 121         k->backend_data = mykeydata = talloc(mem_ctx, struct rpc_key_data);
 122         mykeydata->num_values = -1;
 123         mykeydata->num_subkeys = -1;
 124
 125         /* Then, open the handle using the hive */
 126
 127         memset(&r, 0, sizeof(struct winreg_OpenKey));
 128     r.in.handle = &(((struct rpc_key_data *)k->hive->root->backend_data)->pol);
 129     init_winreg_String(&r.in.keyname, k->path);
 130     r.in.unknown = 0x00000000;
 131     r.in.access_mask = 0x02000000;
 132     r.out.handle = &mykeydata->pol;
 133
 134     dcerpc_winreg_OpenKey((struct dcerpc_pipe *)k->hive->backend_data, mem_ctx, &r);
 135
 136         return r.out.result;
 137 }
 138 #endif
 139
 140 static WERROR rpc_open_key(TALLOC_CTX *mem_ctx, const struct registry_key *h, const char *name, struct registry_key **key)
 141 {
 142         struct rpc_key_data *mykeydata;
 143     struct winreg_OpenKey r;
 144
 145         *key = talloc(mem_ctx, struct registry_key);
 146         (*key)->name = talloc_strdup(mem_ctx, name);
 147
 148         (*key)->backend_data = mykeydata = talloc(mem_ctx, struct rpc_key_data);
 149         mykeydata->num_values = -1;
 150         mykeydata->num_subkeys = -1;
 151
 152         /* Then, open the handle using the hive */
 153
 154         memset(&r, 0, sizeof(struct winreg_OpenKey));
 155     r.in.handle = &(((struct rpc_key_data *)h->backend_data)->pol);
 156     init_winreg_String(&r.in.keyname, name);
 157     r.in.unknown = 0x00000000;
 158     r.in.access_mask = 0x02000000;
 159     r.out.handle = &mykeydata->pol;
 160
 161     dcerpc_winreg_OpenKey((struct dcerpc_pipe *)(h->hive->backend_data), mem_ctx, &r);
 162
 163         return r.out.result;
 164 }
 165
 166 static WERROR rpc_get_value_by_index(TALLOC_CTX *mem_ctx, const struct registry_key *parent, int n, struct registry_value **value)
 167 {
 168         struct rpc_key_data *mykeydata = parent->backend_data;
 169         WERROR error;
 170         struct winreg_EnumValue r;
 171         uint32_t type, len1, zero = 0;
 172         NTSTATUS status;
 173         struct winreg_StringBuf name;
 174         uint8_t u8;
 175
 176         if(mykeydata->num_values == -1) {
 177                 error = rpc_query_key(parent);
 178                 if(!W_ERROR_IS_OK(error)) return error;
 179         }
 180
 181         len1 = mykeydata->max_valdatalen;
 182
 183         name.length = 0;
 184         name.size   = mykeydata->max_valnamelen * 2;
 185         name.name   = "";
 186
 187         r.in.handle = &mykeydata->pol;
 188         r.in.enum_index = n;
 189         r.in.name = &name;
 190         r.in.type = &type;
 191         r.in.value = &u8;
 192         r.in.length = &zero;
 193         r.in.size = &len1;
 194         r.out.name = &name;
 195
 196         status = dcerpc_winreg_EnumValue((struct dcerpc_pipe *)parent->hive->backend_data, mem_ctx, &r);
 197         if(NT_STATUS_IS_ERR(status)) {
 198                 DEBUG(0, ("Error in EnumValue: %s\n", nt_errstr(status)));
 199                 return WERR_GENERAL_FAILURE;
 200         }
 201
 202         if(NT_STATUS_IS_OK(status) &&
 203            W_ERROR_IS_OK(r.out.result) && r.out.length) {
 204                 *value = talloc(mem_ctx, struct registry_value);
 205                 (*value)->name = talloc_strdup(mem_ctx, r.out.name->name);
 206                 (*value)->data_type = type;
 207                 (*value)->data = data_blob_talloc(mem_ctx, r.out.value, *r.out.length);
 208                 return WERR_OK;
 209         }
 210
 211         return r.out.result;
 212 }
 213
 214 static WERROR rpc_get_subkey_by_index(TALLOC_CTX *mem_ctx, const struct registry_key *parent, int n, struct registry_key **subkey)
 215 {
 216         struct winreg_EnumKey r;
 217         struct rpc_key_data *mykeydata = parent->backend_data;
 218         NTSTATUS status;
 219         struct winreg_StringBuf namebuf, classbuf;
 220         NTTIME change_time = 0;
 221
 222         namebuf.length = 0;
 223         namebuf.size   = 1024;
 224         namebuf.name   = NULL;
 225         classbuf.length = 0;
 226         classbuf.size   = 0;
 227         classbuf.name   = NULL;
 228
 229         r.in.handle = &mykeydata->pol;
 230         r.in.enum_index = n;
 231         r.in.name = &namebuf;
 232         r.in.class = &classbuf;
 233         r.in.last_changed_time = &change_time;
 234         r.out.name = &namebuf;
 235
 236         status = dcerpc_winreg_EnumKey((struct dcerpc_pipe *)parent->hive->backend_data, mem_ctx, &r);
 237         if(NT_STATUS_IS_OK(status) && W_ERROR_IS_OK(r.out.result)) {
 238                 char *name = talloc_strdup(mem_ctx, r.out.name->name);
 239                 return rpc_open_key(mem_ctx, parent, name, subkey);
 240         }
 241
 242         return r.out.result;
 243 }
 244
 245 static WERROR rpc_add_key(TALLOC_CTX *mem_ctx, const struct registry_key *parent, const char *name, uint32_t access_mask, struct security_descriptor *sec, struct registry_key **key)
 246 {
 247         NTSTATUS status;
 248         struct winreg_CreateKey r;
 249
 250         init_winreg_String(&r.in.name, name);
 251         init_winreg_String(&r.in.class, NULL);
 252
 253         r.in.handle = parent->backend_data;
 254         r.out.new_handle = talloc(mem_ctx, struct policy_handle);
 255         r.in.options = 0;
 256         r.in.access_mask = access_mask;
 257         r.in.secdesc = NULL;
 258
 259         status = dcerpc_winreg_CreateKey((struct dcerpc_pipe *)(parent->hive->backend_data), mem_ctx, &r);
 260
 261     if (!NT_STATUS_IS_OK(status)) {
 262         DEBUG(1, ("CreateKey failed - %s\n", nt_errstr(status)));
 263         return ntstatus_to_werror(status);
 264     }
 265
 266         if (W_ERROR_IS_OK(r.out.result)) {
 267                 *key = talloc(mem_ctx, struct registry_key);
 268                 (*key)->name = talloc_strdup(*key, name);
 269                 (*key)->backend_data = r.out.new_handle;
 270         }
 271
 272         return r.out.result;
 273 }
 274
 275 static WERROR rpc_query_key(const struct registry_key *k)
 276 {
 277     NTSTATUS status;
 278     struct winreg_QueryInfoKey r;
 279     struct rpc_key_data *mykeydata = k->backend_data;
 280         TALLOC_CTX *mem_ctx = talloc_init("query_key");
 281
 282     init_winreg_String(&r.in.class, NULL);
 283     r.in.handle = &mykeydata->pol;
 284
 285     status = dcerpc_winreg_QueryInfoKey((struct dcerpc_pipe *)(k->hive->backend_data), mem_ctx, &r);
 286         talloc_free(mem_ctx);
 287
 288     if (!NT_STATUS_IS_OK(status)) {
 289         DEBUG(1, ("QueryInfoKey failed - %s\n", nt_errstr(status)));
 290         return ntstatus_to_werror(status);
 291     }
 292
 293     if (W_ERROR_IS_OK(r.out.result)) {
 294                 mykeydata->num_subkeys = r.out.num_subkeys;
 295                 mykeydata->num_values = r.out.num_values;
 296                 mykeydata->max_valnamelen = r.out.max_valnamelen;
 297                 mykeydata->max_valdatalen = r.out.max_valbufsize;
 298         }
 299
 300         return r.out.result;
 301 }
 302
 303 static WERROR rpc_del_key(const struct registry_key *parent, const char *name)
 304 {
 305         NTSTATUS status;
 306         struct rpc_key_data *mykeydata = parent->backend_data;
 307         struct winreg_DeleteKey r;
 308         TALLOC_CTX *mem_ctx = talloc_init("del_key");
 309
 310     r.in.handle = &mykeydata->pol;
 311     init_winreg_String(&r.in.key, name);
 312
 313     status = dcerpc_winreg_DeleteKey((struct dcerpc_pipe *)parent->hive->backend_data, mem_ctx, &r);
 314
 315         talloc_free(mem_ctx);
 316
 317         return r.out.result;
 318 }
 319
 320 static WERROR rpc_num_values(const struct registry_key *key, uint32_t *count)
 321 {
 322         struct rpc_key_data *mykeydata = key->backend_data;
 323         WERROR error;
 324
 325         if(mykeydata->num_values == -1) {
 326                 error = rpc_query_key(key);
 327                 if(!W_ERROR_IS_OK(error)) return error;
 328         }
 329
 330         *count = mykeydata->num_values;
 331         return WERR_OK;
 332 }
 333
 334 static WERROR rpc_num_subkeys(const struct registry_key *key, uint32_t *count)
 335 {
 336         struct rpc_key_data *mykeydata = key->backend_data;
 337         WERROR error;
 338
 339         if(mykeydata->num_subkeys == -1) {
 340                 error = rpc_query_key(key);
 341                 if(!W_ERROR_IS_OK(error)) return error;
 342         }
 343
 344         *count = mykeydata->num_subkeys;
 345         return WERR_OK;
 346 }
 347
 348 static struct hive_operations reg_backend_rpc = {
 349         .name = "rpc",
 350         .open_key = rpc_open_key,
 351         .get_subkey_by_index = rpc_get_subkey_by_index,
 352         .get_value_by_index = rpc_get_value_by_index,
 353         .add_key = rpc_add_key,
 354         .del_key = rpc_del_key,
 355         .num_subkeys = rpc_num_subkeys,
 356         .num_values = rpc_num_values,
 357 };
 358
 359 _PUBLIC_ WERROR reg_open_remote(struct registry_context **ctx, struct cli_credentials *credentials,
 360                        const char *location, struct event_context *ev)
 361 {
 362         NTSTATUS status;
 363         struct dcerpc_pipe *p;
 364
 365         *ctx = talloc(NULL, struct registry_context);
 366
 367         /* Default to local smbd if no connection is specified */
 368         if (!location) {
 369                 location = talloc_strdup(ctx, "ncalrpc:");
 370         }
 371
 372         status = dcerpc_pipe_connect(*ctx /* TALLOC_CTX */,
 373                                      &p, location,
 374                                          &dcerpc_table_winreg,
 375                                      credentials, ev);
 376         (*ctx)->backend_data = p;
 377
 378         if(NT_STATUS_IS_ERR(status)) {
 379                 DEBUG(1, ("Unable to open '%s': %s\n", location, nt_errstr(status)));
 380                 talloc_free(*ctx);
 381                 *ctx = NULL;
 382                 return ntstatus_to_werror(status);
 383         }
 384
 385         (*ctx)->get_predefined_key = rpc_get_predefined_key;
 386
 387         return WERR_OK;
 388 }
 389
 390 NTSTATUS registry_rpc_init(void)
 391 {
 392         dcerpc_init();
 393         return registry_register(&reg_backend_rpc);
 394 }