source4/librpc/rpc/dcerpc_schannel.c

   1 /*
   2    Unix SMB/CIFS implementation.
   3
   4    dcerpc schannel operations
   5
   6    Copyright (C) Andrew Tridgell 2004
   7
   8    This program is free software; you can redistribute it and/or modify
   9    it under the terms of the GNU General Public License as published by
  10    the Free Software Foundation; either version 2 of the License, or
  11    (at your option) any later version.
  12
  13    This program is distributed in the hope that it will be useful,
  14    but WITHOUT ANY WARRANTY; without even the implied warranty of
  15    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  16    GNU General Public License for more details.
  17
  18    You should have received a copy of the GNU General Public License
  19    along with this program; if not, write to the Free Software
  20    Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
  21 */
  22
  23 #include "includes.h"
  24 #include "librpc/gen_ndr/ndr_schannel.h"
  25 #include "auth/auth.h"
  26
  27 enum schannel_position {
  28         DCERPC_SCHANNEL_STATE_START = 0,
  29         DCERPC_SCHANNEL_STATE_UPDATE_1
  30 };
  31
  32 struct dcerpc_schannel_state {
  33         enum schannel_position state;
  34         struct schannel_state *schannel_state;
  35         struct creds_CredentialState *creds;
  36         char *account_name;
  37 };
  38
  39 static NTSTATUS dcerpc_schannel_key(struct dcerpc_pipe *p,
  40                                     const char *domain,
  41                                     const char *username,
  42                                     const char *password,
  43                                     int chan_type,
  44                                     struct creds_CredentialState *creds);
  45
  46 /*
  47   wrappers for the schannel_*() functions
  48
  49   These will become static again, when we get dynamic registration, and
  50   decrpc_schannel_security_ops come back here.
  51 */
  52 static NTSTATUS dcerpc_schannel_unseal_packet(struct gensec_security *gensec_security,
  53                                               TALLOC_CTX *mem_ctx,
  54                                               uint8_t *data, size_t length,
  55                                               const uint8_t *whole_pdu, size_t pdu_length,
  56                                               DATA_BLOB *sig)
  57 {
  58         struct dcerpc_schannel_state *dce_schan_state = gensec_security->private_data;
  59
  60         return schannel_unseal_packet(dce_schan_state->schannel_state, mem_ctx, data, length, sig);
  61 }
  62
  63 static NTSTATUS dcerpc_schannel_check_packet(struct gensec_security *gensec_security,
  64                                              TALLOC_CTX *mem_ctx,
  65                                              const uint8_t *data, size_t length,
  66                                              const uint8_t *whole_pdu, size_t pdu_length,
  67                                              const DATA_BLOB *sig)
  68 {
  69         struct dcerpc_schannel_state *dce_schan_state = gensec_security->private_data;
  70
  71         return schannel_check_packet(dce_schan_state->schannel_state, data, length, sig);
  72 }
  73
  74 static NTSTATUS dcerpc_schannel_seal_packet(struct gensec_security *gensec_security,
  75                                             TALLOC_CTX *mem_ctx,
  76                                             uint8_t *data, size_t length,
  77                                             const uint8_t *whole_pdu, size_t pdu_length,
  78                                             DATA_BLOB *sig)
  79 {
  80         struct dcerpc_schannel_state *dce_schan_state = gensec_security->private_data;
  81
  82         return schannel_seal_packet(dce_schan_state->schannel_state, mem_ctx, data, length, sig);
  83 }
  84
  85 static NTSTATUS dcerpc_schannel_sign_packet(struct gensec_security *gensec_security,
  86                                             TALLOC_CTX *mem_ctx,
  87                                             const uint8_t *data, size_t length,
  88                                             const uint8_t *whole_pdu, size_t pdu_length,
  89                                             DATA_BLOB *sig)
  90 {
  91         struct dcerpc_schannel_state *dce_schan_state = gensec_security->private_data;
  92
  93         return schannel_sign_packet(dce_schan_state->schannel_state, mem_ctx, data, length, sig);
  94 }
  95
  96 static size_t dcerpc_schannel_sig_size(struct gensec_security *gensec_security)
  97 {
  98         return 32;
  99 }
 100
 101 static NTSTATUS dcerpc_schannel_session_key(struct gensec_security *gensec_security,
 102                                             DATA_BLOB *session_key)
 103 {
 104         return NT_STATUS_NOT_IMPLEMENTED;
 105 }
 106
 107 static NTSTATUS dcerpc_schannel_update(struct gensec_security *gensec_security, TALLOC_CTX *out_mem_ctx,
 108                                        const DATA_BLOB in, DATA_BLOB *out)
 109 {
 110         struct dcerpc_schannel_state *dce_schan_state = gensec_security->private_data;
 111         NTSTATUS status;
 112         struct schannel_bind bind_schannel;
 113         struct schannel_bind_ack bind_schannel_ack;
 114         const char *account_name;
 115         *out = data_blob(NULL, 0);
 116
 117         switch (gensec_security->gensec_role) {
 118         case GENSEC_CLIENT:
 119                 if (dce_schan_state->state != DCERPC_SCHANNEL_STATE_START) {
 120                         /* we could parse the bind ack, but we don't know what it is yet */
 121                         return NT_STATUS_OK;
 122                 }
 123
 124                 status = schannel_start(&dce_schan_state->schannel_state,
 125                                         dce_schan_state->creds->session_key,
 126                                         True);
 127                 if (!NT_STATUS_IS_OK(status)) {
 128                         DEBUG(1, ("Failed to start schannel client\n"));
 129                         return status;
 130                 }
 131                 talloc_steal(dce_schan_state, dce_schan_state->schannel_state);
 132
 133                 bind_schannel.unknown1 = 0;
 134 #if 0
 135                 /* to support this we'd need to have access to the full domain name */
 136                 bind_schannel.bind_type = 23;
 137                 bind_schannel.u.info23.domain = gensec_security->user.domain;
 138                 bind_schannel.u.info23.account_name = gensec_security->user.name;
 139                 bind_schannel.u.info23.dnsdomain = str_format_nbt_domain(out_mem_ctx, fulldomainname);
 140                 bind_schannel.u.info23.workstation = str_format_nbt_domain(out_mem_ctx, gensec_security->user.name);
 141 #else
 142                 bind_schannel.bind_type = 3;
 143                 bind_schannel.u.info3.domain = gensec_security->user.domain;
 144                 bind_schannel.u.info3.account_name = gensec_security->user.name;
 145 #endif
 146
 147                 status = ndr_push_struct_blob(out, out_mem_ctx, &bind_schannel,
 148                                               (ndr_push_flags_fn_t)ndr_push_schannel_bind);
 149                 if (!NT_STATUS_IS_OK(status)) {
 150                         DEBUG(3, ("Could not create schannel bind: %s\n",
 151                                   nt_errstr(status)));
 152                         return status;
 153                 }
 154
 155                 dce_schan_state->state = DCERPC_SCHANNEL_STATE_UPDATE_1;
 156
 157                 return NT_STATUS_MORE_PROCESSING_REQUIRED;
 158         case GENSEC_SERVER:
 159
 160                 if (dce_schan_state->state != DCERPC_SCHANNEL_STATE_START) {
 161                         /* no third leg on this protocol */
 162                         return NT_STATUS_INVALID_PARAMETER;
 163                 }
 164
 165                 /* parse the schannel startup blob */
 166                 status = ndr_pull_struct_blob(&in, out_mem_ctx, &bind_schannel,
 167                                               (ndr_pull_flags_fn_t)ndr_pull_schannel_bind);
 168                 if (!NT_STATUS_IS_OK(status)) {
 169                         return status;
 170                 }
 171
 172                 if (bind_schannel.bind_type == 23) {
 173                         account_name = bind_schannel.u.info23.account_name;
 174                 } else {
 175                         account_name = bind_schannel.u.info3.account_name;
 176                 }
 177
 178                 /* pull the session key for this client */
 179                 status = schannel_fetch_session_key(out_mem_ctx, account_name, &dce_schan_state->creds);
 180                 if (!NT_STATUS_IS_OK(status)) {
 181                         DEBUG(3, ("Could not find session key for attempted schannel connection on %s: %s\n",
 182                                   account_name, nt_errstr(status)));
 183                         return status;
 184                 }
 185
 186                 dce_schan_state->account_name = talloc_strdup(dce_schan_state, account_name);
 187
 188                 /* start up the schannel server code */
 189                 status = schannel_start(&dce_schan_state->schannel_state,
 190                                         dce_schan_state->creds->session_key, False);
 191                 if (!NT_STATUS_IS_OK(status)) {
 192                         DEBUG(3, ("Could not initialise schannel state for account %s: %s\n",
 193                                   account_name, nt_errstr(status)));
 194                         return status;
 195                 }
 196                 talloc_steal(dce_schan_state, dce_schan_state->schannel_state);
 197
 198                 bind_schannel_ack.unknown1 = 1;
 199                 bind_schannel_ack.unknown2 = 0;
 200                 bind_schannel_ack.unknown3 = 0x6c0000;
 201
 202                 status = ndr_push_struct_blob(out, out_mem_ctx, &bind_schannel_ack,
 203                                               (ndr_push_flags_fn_t)ndr_push_schannel_bind_ack);
 204                 if (!NT_STATUS_IS_OK(status)) {
 205                         DEBUG(3, ("Could not return schannel bind ack for account %s: %s\n",
 206                                   account_name, nt_errstr(status)));
 207                         return status;
 208                 }
 209
 210                 dce_schan_state->state = DCERPC_SCHANNEL_STATE_UPDATE_1;
 211
 212                 return NT_STATUS_OK;
 213         }
 214         return NT_STATUS_INVALID_PARAMETER;
 215 }
 216
 217 /**
 218  * Return the credentials of a logged on user, including session keys
 219  * etc.
 220  *
 221  * Only valid after a successful authentication
 222  *
 223  * May only be called once per authentication.
 224  *
 225  */
 226
 227 NTSTATUS dcerpc_schannel_session_info(struct gensec_security *gensec_security,
 228                                       struct auth_session_info **session_info)
 229 {
 230         struct dcerpc_schannel_state *dce_schan_state = gensec_security->private_data;
 231
 232         (*session_info) = talloc_p(gensec_security, struct auth_session_info);
 233         if (*session_info == NULL) {
 234                 return NT_STATUS_NO_MEMORY;
 235         }
 236
 237         ZERO_STRUCTP(*session_info);
 238         (*session_info)->refcount = 1;
 239
 240         (*session_info)->workstation = talloc_strdup(*session_info, dce_schan_state->account_name);
 241         if ((*session_info)->workstation == NULL) {
 242                 talloc_free(*session_info);
 243                 return NT_STATUS_NO_MEMORY;
 244         }
 245         return NT_STATUS_OK;
 246 }
 247
 248
 249 /**
 250  * Return the struct creds_CredentialState.
 251  *
 252  * Make sure not to call this unless gensec is using schannel...
 253  */
 254
 255 NTSTATUS dcerpc_schannel_creds(struct gensec_security *gensec_security,
 256                                TALLOC_CTX *mem_ctx,
 257                                struct creds_CredentialState **creds)
 258 {
 259         struct dcerpc_schannel_state *dce_schan_state = gensec_security->private_data;
 260
 261         *creds = talloc_reference(mem_ctx, dce_schan_state->creds);
 262         if (!*creds) {
 263                 return NT_STATUS_NO_MEMORY;
 264         }
 265         return NT_STATUS_OK;
 266 }
 267
 268
 269 /*
 270   end crypto state
 271 */
 272 static int dcerpc_schannel_destroy(void *ptr)
 273 {
 274         struct dcerpc_schannel_state *dce_schan_state = ptr;
 275
 276         schannel_end(&dce_schan_state->schannel_state);
 277
 278         return 0;
 279 }
 280
 281 static NTSTATUS dcerpc_schannel_start(struct gensec_security *gensec_security)
 282 {
 283         struct dcerpc_schannel_state *dce_schan_state;
 284
 285         dce_schan_state = talloc_p(gensec_security, struct dcerpc_schannel_state);
 286         if (!dce_schan_state) {
 287                 return NT_STATUS_NO_MEMORY;
 288         }
 289
 290         dce_schan_state->state = DCERPC_SCHANNEL_STATE_START;
 291         gensec_security->private_data = dce_schan_state;
 292
 293         talloc_set_destructor(dce_schan_state, dcerpc_schannel_destroy);
 294
 295         return NT_STATUS_OK;
 296 }
 297
 298 static NTSTATUS dcerpc_schannel_server_start(struct gensec_security *gensec_security)
 299 {
 300         NTSTATUS status;
 301
 302         status = dcerpc_schannel_start(gensec_security);
 303         if (!NT_STATUS_IS_OK(status)) {
 304                 return status;
 305         }
 306
 307         return NT_STATUS_OK;
 308 }
 309
 310 static NTSTATUS dcerpc_schannel_client_start(struct gensec_security *gensec_security)
 311 {
 312         NTSTATUS status;
 313
 314         status = dcerpc_schannel_start(gensec_security);
 315         if (!NT_STATUS_IS_OK(status)) {
 316                 return status;
 317         }
 318
 319         return NT_STATUS_OK;
 320 }
 321
 322
 323 /*
 324   get a schannel key using a netlogon challenge on a secondary pipe
 325 */
 326 static NTSTATUS dcerpc_schannel_key(struct dcerpc_pipe *p,
 327                                     const char *domain,
 328                                     const char *username,
 329                                     const char *password,
 330                                     int chan_type,
 331                                     struct creds_CredentialState *creds)
 332 {
 333         NTSTATUS status;
 334         struct dcerpc_pipe *p2;
 335         struct netr_ServerReqChallenge r;
 336         struct netr_ServerAuthenticate2 a;
 337         struct netr_Credential credentials1, credentials2, credentials3;
 338         struct samr_Password mach_pwd;
 339         const char *workgroup, *workstation;
 340         uint32_t negotiate_flags;
 341
 342         if (p->flags & DCERPC_SCHANNEL_128) {
 343                 negotiate_flags = NETLOGON_NEG_AUTH2_ADS_FLAGS;
 344         } else {
 345                 negotiate_flags = NETLOGON_NEG_AUTH2_FLAGS;
 346         }
 347
 348         workstation = username;
 349         workgroup = domain;
 350
 351         /*
 352           step 1 - establish a netlogon connection, with no authentication
 353         */
 354         status = dcerpc_secondary_connection(p, &p2,
 355                                              DCERPC_NETLOGON_NAME,
 356                                              DCERPC_NETLOGON_UUID,
 357                                              DCERPC_NETLOGON_VERSION);
 358         if (!NT_STATUS_IS_OK(status)) {
 359                 return status;
 360         }
 361
 362
 363         /*
 364           step 2 - request a netlogon challenge
 365         */
 366         r.in.server_name = talloc_asprintf(p, "\\\\%s", dcerpc_server_name(p));
 367         r.in.computer_name = workstation;
 368         r.in.credentials = &credentials1;
 369         r.out.credentials = &credentials2;
 370
 371         generate_random_buffer(credentials1.data, sizeof(credentials1.data));
 372
 373         status = dcerpc_netr_ServerReqChallenge(p2, p, &r);
 374         if (!NT_STATUS_IS_OK(status)) {
 375                 return status;
 376         }
 377
 378         /*
 379           step 3 - authenticate on the netlogon pipe
 380         */
 381         E_md4hash(password, mach_pwd.hash);
 382         creds_client_init(creds, &credentials1, &credentials2, &mach_pwd, &credentials3,
 383                           negotiate_flags);
 384
 385         a.in.server_name = r.in.server_name;
 386         a.in.account_name = talloc_asprintf(p, "%s$", workstation);
 387         a.in.secure_channel_type = chan_type;
 388         a.in.computer_name = workstation;
 389         a.in.negotiate_flags = &negotiate_flags;
 390         a.out.negotiate_flags = &negotiate_flags;
 391         a.in.credentials = &credentials3;
 392         a.out.credentials = &credentials3;
 393
 394         status = dcerpc_netr_ServerAuthenticate2(p2, p, &a);
 395         if (!NT_STATUS_IS_OK(status)) {
 396                 return status;
 397         }
 398
 399         if (!creds_client_check(creds, a.out.credentials)) {
 400                 return NT_STATUS_UNSUCCESSFUL;
 401         }
 402
 403         /*
 404           the schannel session key is now in creds.session_key
 405
 406           we no longer need the netlogon pipe open
 407         */
 408         dcerpc_pipe_close(p2);
 409
 410         return NT_STATUS_OK;
 411 }
 412
 413 /*
 414   do a schannel style bind on a dcerpc pipe. The username is usually
 415   of the form HOSTNAME$ and the password is the domain trust password
 416 */
 417 NTSTATUS dcerpc_bind_auth_schannel_withkey(struct dcerpc_pipe *p,
 418                                            const char *uuid, uint_t version,
 419                                            const char *domain,
 420                                            const char *username,
 421                                            const char *password,
 422                                            struct creds_CredentialState *creds)
 423 {
 424         NTSTATUS status;
 425         struct dcerpc_schannel_state *dce_schan_state;
 426
 427         status = gensec_client_start(p, &p->security_state.generic_state);
 428         if (!NT_STATUS_IS_OK(status)) {
 429                 return status;
 430         }
 431
 432         status = gensec_set_username(p->security_state.generic_state, username);
 433         if (!NT_STATUS_IS_OK(status)) {
 434                 DEBUG(1, ("Failed to set schannel username to %s: %s\n", username, nt_errstr(status)));
 435                 talloc_free(p->security_state.generic_state);
 436                 p->security_state.generic_state = NULL;
 437                 return status;
 438         }
 439
 440         status = gensec_set_domain(p->security_state.generic_state, domain);
 441         if (!NT_STATUS_IS_OK(status)) {
 442                 DEBUG(1, ("Failed to set schannel domain to %s: %s\n", domain, nt_errstr(status)));
 443                 talloc_free(p->security_state.generic_state);
 444                 p->security_state.generic_state = NULL;
 445                 return status;
 446         }
 447
 448         status = gensec_start_mech_by_authtype(p->security_state.generic_state, DCERPC_AUTH_TYPE_SCHANNEL, dcerpc_auth_level(p));
 449
 450         if (!NT_STATUS_IS_OK(status)) {
 451                 DEBUG(1, ("Failed to start SCHANNEL GENSEC backend: %s\n", nt_errstr(status)));
 452                 talloc_free(p->security_state.generic_state);
 453                 p->security_state.generic_state = NULL;
 454                 return status;
 455         }
 456
 457         dce_schan_state = p->security_state.generic_state->private_data;
 458         dce_schan_state->creds = talloc_reference(dce_schan_state, creds);
 459
 460         status = dcerpc_bind_auth3(p, DCERPC_AUTH_TYPE_SCHANNEL, dcerpc_auth_level(p),
 461                                   uuid, version);
 462
 463         if (!NT_STATUS_IS_OK(status)) {
 464                 DEBUG(1, ("Failed to bind to pipe with SCHANNEL: %s\n", nt_errstr(status)));
 465                 talloc_free(p->security_state.generic_state);
 466                 p->security_state.generic_state = NULL;
 467                 return status;
 468         }
 469
 470         return NT_STATUS_OK;
 471 }
 472
 473 NTSTATUS dcerpc_bind_auth_schannel(struct dcerpc_pipe *p,
 474                                    const char *uuid, uint_t version,
 475                                    const char *domain,
 476                                    const char *username,
 477                                    const char *password)
 478 {
 479         NTSTATUS status;
 480         int chan_type = 0;
 481         struct creds_CredentialState *creds;
 482         creds = talloc_p(p, struct creds_CredentialState);
 483         if (!creds) {
 484                 return NT_STATUS_NO_MEMORY;
 485         }
 486
 487         if (p->flags & DCERPC_SCHANNEL_BDC) {
 488                 chan_type = SEC_CHAN_BDC;
 489         } else if (p->flags & DCERPC_SCHANNEL_WORKSTATION) {
 490                 chan_type = SEC_CHAN_WKSTA;
 491         } else if (p->flags & DCERPC_SCHANNEL_DOMAIN) {
 492                 chan_type = SEC_CHAN_DOMAIN;
 493         }
 494
 495         status = dcerpc_schannel_key(p, domain,
 496                                      username,
 497                                      password,
 498                                      chan_type,
 499                                      creds);
 500
 501         if (!NT_STATUS_IS_OK(status)) {
 502                 DEBUG(1, ("Failed to fetch schannel session key: %s\n",
 503                           nt_errstr(status)));
 504                 return status;
 505         }
 506
 507         return dcerpc_bind_auth_schannel_withkey(p, uuid, version, domain,
 508                                                  username, password,
 509                                                  creds);
 510 }
 511
 512 static BOOL dcerpc_schannel_have_feature(struct gensec_security *gensec_security,
 513                                           uint32 feature)
 514 {
 515         if (feature & (GENSEC_FEATURE_SESSION_KEY |
 516                        GENSEC_FEATURE_SIGN |
 517                        GENSEC_FEATURE_SEAL)) {
 518                 return True;
 519         }
 520         return False;
 521 }
 522
 523
 524 static const struct gensec_security_ops gensec_dcerpc_schannel_security_ops = {
 525         .name           = "dcerpc_schannel",
 526         .auth_type      = DCERPC_AUTH_TYPE_SCHANNEL,
 527         .client_start   = dcerpc_schannel_client_start,
 528         .server_start   = dcerpc_schannel_server_start,
 529         .update         = dcerpc_schannel_update,
 530         .seal_packet    = dcerpc_schannel_seal_packet,
 531         .sign_packet    = dcerpc_schannel_sign_packet,
 532         .check_packet   = dcerpc_schannel_check_packet,
 533         .unseal_packet  = dcerpc_schannel_unseal_packet,
 534         .session_key    = dcerpc_schannel_session_key,
 535         .session_info   = dcerpc_schannel_session_info,
 536         .sig_size       = dcerpc_schannel_sig_size,
 537         .have_feature  = dcerpc_schannel_have_feature
 538 };
 539
 540 NTSTATUS gensec_dcerpc_schannel_init(void)
 541 {
 542         NTSTATUS ret;
 543         ret = gensec_register(&gensec_dcerpc_schannel_security_ops);
 544         if (!NT_STATUS_IS_OK(ret)) {
 545                 DEBUG(0,("Failed to register '%s' gensec backend!\n",
 546                         gensec_dcerpc_schannel_security_ops.name));
 547                 return ret;
 548         }
 549
 550         return ret;
 551 }