git.sur5r.net Git - openldap/blob - libraries/libldap/cyrus.c

   1 /* $OpenLDAP$ */
   2 /*
   3  * Copyright 1999-2003 The OpenLDAP Foundation, All Rights Reserved.
   4  * COPYING RESTRICTIONS APPLY, see COPYRIGHT file
   5  */
   6
   7 #include "portable.h"
   8
   9 #include <stdio.h>
  10
  11 #include <ac/socket.h>
  12 #include <ac/stdlib.h>
  13 #include <ac/string.h>
  14 #include <ac/time.h>
  15 #include <ac/errno.h>
  16 #include <ac/ctype.h>
  17
  18 #include "ldap-int.h"
  19
  20 #ifdef HAVE_CYRUS_SASL
  21
  22 #ifdef LDAP_R_COMPILE
  23 ldap_pvt_thread_mutex_t ldap_int_sasl_mutex;
  24 #endif
  25
  26 #ifdef HAVE_SASL_SASL_H
  27 #include <sasl/sasl.h>
  28 #else
  29 #include <sasl.h>
  30 #endif
  31
  32 #if SASL_VERSION_MAJOR >= 2
  33 #define SASL_CONST const
  34 #else
  35 #define SASL_CONST
  36 #endif
  37
  38 /*
  39 * Various Cyrus SASL related stuff.
  40 */
  41
  42 int ldap_int_sasl_init( void )
  43 {
  44         /* XXX not threadsafe */
  45         static int sasl_initialized = 0;
  46
  47         static sasl_callback_t client_callbacks[] = {
  48 #ifdef SASL_CB_GETREALM
  49                 { SASL_CB_GETREALM, NULL, NULL },
  50 #endif
  51                 { SASL_CB_USER, NULL, NULL },
  52                 { SASL_CB_AUTHNAME, NULL, NULL },
  53                 { SASL_CB_PASS, NULL, NULL },
  54                 { SASL_CB_ECHOPROMPT, NULL, NULL },
  55                 { SASL_CB_NOECHOPROMPT, NULL, NULL },
  56                 { SASL_CB_LIST_END, NULL, NULL }
  57         };
  58
  59 #ifdef HAVE_SASL_VERSION
  60 #define SASL_BUILD_VERSION ((SASL_VERSION_MAJOR << 24) |\
  61         (SASL_VERSION_MINOR << 16) | SASL_VERSION_STEP)
  62
  63         { int rc;
  64         sasl_version( NULL, &rc );
  65         if ( ((rc >> 16) != ((SASL_VERSION_MAJOR << 8)|SASL_VERSION_MINOR)) ||
  66                 (rc & 0xffff) < SASL_VERSION_STEP) {
  67
  68 #ifdef NEW_LOGGING
  69                 LDAP_LOG( TRANSPORT, INFO,
  70                 "ldap_int_sasl_init: SASL version mismatch, got %x, wanted %x.\n",
  71                         rc, SASL_BUILD_VERSION, 0 );
  72 #else
  73                 Debug( LDAP_DEBUG_ANY,
  74                 "ldap_int_sasl_init: SASL version mismatch, got %x, wanted %x.\n",
  75                         rc, SASL_BUILD_VERSION, 0 );
  76 #endif
  77                 return -1;
  78         }
  79         }
  80 #endif
  81         if ( sasl_initialized ) {
  82                 return 0;
  83         }
  84
  85 /* SASL 2 takes care of its own memory completely internally */
  86 #if SASL_VERSION_MAJOR < 2 && !defined(CSRIMALLOC)
  87         sasl_set_alloc(
  88                 ber_memalloc,
  89                 ber_memcalloc,
  90                 ber_memrealloc,
  91                 ber_memfree );
  92 #endif /* CSRIMALLOC */
  93
  94 #ifdef LDAP_R_COMPILE
  95         sasl_set_mutex(
  96                 ldap_pvt_sasl_mutex_new,
  97                 ldap_pvt_sasl_mutex_lock,
  98                 ldap_pvt_sasl_mutex_unlock,
  99                 ldap_pvt_sasl_mutex_dispose );
 100
 101         ldap_pvt_thread_mutex_init( &ldap_int_sasl_mutex );
 102 #endif
 103
 104         if ( sasl_client_init( client_callbacks ) == SASL_OK ) {
 105                 sasl_initialized = 1;
 106                 return 0;
 107         }
 108
 109 #if SASL_VERSION_MAJOR < 2
 110         /* A no-op to make sure we link with Cyrus 1.5 */
 111         sasl_client_auth( NULL, NULL, NULL, 0, NULL, NULL );
 112 #endif
 113         return -1;
 114 }
 115
 116 /*
 117  * SASL encryption support for LBER Sockbufs
 118  */
 119
 120 struct sb_sasl_data {
 121         sasl_conn_t             *sasl_context;
 122         unsigned                *sasl_maxbuf;
 123         Sockbuf_Buf             sec_buf_in;
 124         Sockbuf_Buf             buf_in;
 125         Sockbuf_Buf             buf_out;
 126 };
 127
 128 static int
 129 sb_sasl_setup( Sockbuf_IO_Desc *sbiod, void *arg )
 130 {
 131         struct sb_sasl_data     *p;
 132
 133         assert( sbiod != NULL );
 134
 135         p = LBER_MALLOC( sizeof( *p ) );
 136         if ( p == NULL )
 137                 return -1;
 138         p->sasl_context = (sasl_conn_t *)arg;
 139         ber_pvt_sb_buf_init( &p->sec_buf_in );
 140         ber_pvt_sb_buf_init( &p->buf_in );
 141         ber_pvt_sb_buf_init( &p->buf_out );
 142         if ( ber_pvt_sb_grow_buffer( &p->sec_buf_in, SASL_MIN_BUFF_SIZE ) < 0 ) {
 143                 LBER_FREE( p );
 144                 errno = ENOMEM;
 145                 return -1;
 146         }
 147         sasl_getprop( p->sasl_context, SASL_MAXOUTBUF,
 148                 (SASL_CONST void **) &p->sasl_maxbuf );
 149
 150         sbiod->sbiod_pvt = p;
 151
 152         return 0;
 153 }
 154
 155 static int
 156 sb_sasl_remove( Sockbuf_IO_Desc *sbiod )
 157 {
 158         struct sb_sasl_data     *p;
 159
 160         assert( sbiod != NULL );
 161
 162         p = (struct sb_sasl_data *)sbiod->sbiod_pvt;
 163 #if SASL_VERSION_MAJOR >= 2
 164         /*
 165          * SASLv2 encode/decode buffers are managed by
 166          * libsasl2. Ensure they are not freed by liblber.
 167          */
 168         p->buf_in.buf_base = NULL;
 169         p->buf_out.buf_base = NULL;
 170 #endif
 171         ber_pvt_sb_buf_destroy( &p->sec_buf_in );
 172         ber_pvt_sb_buf_destroy( &p->buf_in );
 173         ber_pvt_sb_buf_destroy( &p->buf_out );
 174         LBER_FREE( p );
 175         sbiod->sbiod_pvt = NULL;
 176         return 0;
 177 }
 178
 179 static ber_len_t
 180 sb_sasl_pkt_length( const unsigned char *buf, unsigned max, int debuglevel )
 181 {
 182         ber_len_t               size;
 183
 184         assert( buf != NULL );
 185
 186         size = buf[0] << 24
 187                 | buf[1] << 16
 188                 | buf[2] << 8
 189                 | buf[3];
 190
 191         if ( size > SASL_MAX_BUFF_SIZE ) {
 192                 /* somebody is trying to mess me up. */
 193                 ber_log_printf( LDAP_DEBUG_ANY, debuglevel,
 194                         "sb_sasl_pkt_length: received illegal packet length "
 195                         "of %lu bytes\n", (unsigned long)size );
 196                 size = 16; /* this should lead to an error. */
 197         }
 198
 199         return size + 4; /* include the size !!! */
 200 }
 201
 202 /* Drop a processed packet from the input buffer */
 203 static void
 204 sb_sasl_drop_packet ( Sockbuf_Buf *sec_buf_in, unsigned max, int debuglevel )
 205 {
 206         ber_slen_t                      len;
 207
 208         len = sec_buf_in->buf_ptr - sec_buf_in->buf_end;
 209         if ( len > 0 )
 210                 AC_MEMCPY( sec_buf_in->buf_base, sec_buf_in->buf_base +
 211                         sec_buf_in->buf_end, len );
 212
 213         if ( len >= 4 ) {
 214                 sec_buf_in->buf_end = sb_sasl_pkt_length(
 215                         (unsigned char *) sec_buf_in->buf_base, max, debuglevel);
 216         }
 217         else {
 218                 sec_buf_in->buf_end = 0;
 219         }
 220         sec_buf_in->buf_ptr = len;
 221 }
 222
 223 static ber_slen_t
 224 sb_sasl_read( Sockbuf_IO_Desc *sbiod, void *buf, ber_len_t len)
 225 {
 226         struct sb_sasl_data     *p;
 227         ber_slen_t              ret, bufptr;
 228
 229         assert( sbiod != NULL );
 230         assert( SOCKBUF_VALID( sbiod->sbiod_sb ) );
 231
 232         p = (struct sb_sasl_data *)sbiod->sbiod_pvt;
 233
 234         /* Are there anything left in the buffer? */
 235         ret = ber_pvt_sb_copy_out( &p->buf_in, buf, len );
 236         bufptr = ret;
 237         len -= ret;
 238
 239         if ( len == 0 )
 240                 return bufptr;
 241
 242 #if SASL_VERSION_MAJOR >= 2
 243         ber_pvt_sb_buf_init( &p->buf_in );
 244 #else
 245         ber_pvt_sb_buf_destroy( &p->buf_in );
 246 #endif
 247
 248         /* Read the length of the packet */
 249         while ( p->sec_buf_in.buf_ptr < 4 ) {
 250                 ret = LBER_SBIOD_READ_NEXT( sbiod, p->sec_buf_in.buf_base,
 251                         4 - p->sec_buf_in.buf_ptr );
 252 #ifdef EINTR
 253                 if ( ( ret < 0 ) && ( errno == EINTR ) )
 254                         continue;
 255 #endif
 256                 if ( ret <= 0 )
 257                         return bufptr ? bufptr : ret;
 258
 259                 p->sec_buf_in.buf_ptr += ret;
 260         }
 261
 262         /* The new packet always starts at p->sec_buf_in.buf_base */
 263         ret = sb_sasl_pkt_length( (unsigned char *) p->sec_buf_in.buf_base,
 264                 *p->sasl_maxbuf, sbiod->sbiod_sb->sb_debug );
 265
 266         /* Grow the packet buffer if neccessary */
 267         if ( ( p->sec_buf_in.buf_size < (ber_len_t) ret ) &&
 268                 ber_pvt_sb_grow_buffer( &p->sec_buf_in, ret ) < 0 )
 269         {
 270                 errno = ENOMEM;
 271                 return -1;
 272         }
 273         p->sec_buf_in.buf_end = ret;
 274
 275         /* Did we read the whole encrypted packet? */
 276         while ( p->sec_buf_in.buf_ptr < p->sec_buf_in.buf_end ) {
 277                 /* No, we have got only a part of it */
 278                 ret = p->sec_buf_in.buf_end - p->sec_buf_in.buf_ptr;
 279
 280                 ret = LBER_SBIOD_READ_NEXT( sbiod, p->sec_buf_in.buf_base +
 281                         p->sec_buf_in.buf_ptr, ret );
 282 #ifdef EINTR
 283                 if ( ( ret < 0 ) && ( errno == EINTR ) )
 284                         continue;
 285 #endif
 286                 if ( ret <= 0 )
 287                         return bufptr ? bufptr : ret;
 288
 289                 p->sec_buf_in.buf_ptr += ret;
 290         }
 291
 292         /* Decode the packet */
 293         ret = sasl_decode( p->sasl_context, p->sec_buf_in.buf_base,
 294                 p->sec_buf_in.buf_end,
 295                 (SASL_CONST char **)&p->buf_in.buf_base,
 296                 (unsigned *)&p->buf_in.buf_end );
 297
 298         /* Drop the packet from the input buffer */
 299         sb_sasl_drop_packet( &p->sec_buf_in,
 300                         *p->sasl_maxbuf, sbiod->sbiod_sb->sb_debug );
 301
 302         if ( ret != SASL_OK ) {
 303                 ber_log_printf( LDAP_DEBUG_ANY, sbiod->sbiod_sb->sb_debug,
 304                         "sb_sasl_read: failed to decode packet: %s\n",
 305                         sasl_errstring( ret, NULL, NULL ) );
 306                 errno = EIO;
 307                 return -1;
 308         }
 309
 310         p->buf_in.buf_size = p->buf_in.buf_end;
 311
 312         bufptr += ber_pvt_sb_copy_out( &p->buf_in, (char*) buf + bufptr, len );
 313
 314         return bufptr;
 315 }
 316
 317 static ber_slen_t
 318 sb_sasl_write( Sockbuf_IO_Desc *sbiod, void *buf, ber_len_t len)
 319 {
 320         struct sb_sasl_data     *p;
 321         int                     ret;
 322
 323         assert( sbiod != NULL );
 324         assert( SOCKBUF_VALID( sbiod->sbiod_sb ) );
 325
 326         p = (struct sb_sasl_data *)sbiod->sbiod_pvt;
 327
 328         /* Are there anything left in the buffer? */
 329         if ( p->buf_out.buf_ptr != p->buf_out.buf_end ) {
 330                 ret = ber_pvt_sb_do_write( sbiod, &p->buf_out );
 331                 if ( ret < 0 )
 332                         return ret;
 333                 /* Still have something left?? */
 334                 if ( p->buf_out.buf_ptr != p->buf_out.buf_end ) {
 335                         errno = EAGAIN;
 336                         return 0;
 337                 }
 338         }
 339
 340         /* now encode the next packet. */
 341 #if SASL_VERSION_MAJOR >= 2
 342         ber_pvt_sb_buf_init( &p->buf_out );
 343         /* sasl v2 makes sure this number is correct */
 344         if ( len > *p->sasl_maxbuf )
 345                 len = *p->sasl_maxbuf;
 346 #else
 347         ber_pvt_sb_buf_destroy( &p->buf_out );
 348         if ( len > *p->sasl_maxbuf - 100 )
 349                 len = *p->sasl_maxbuf - 100;    /* For safety margin */
 350 #endif
 351         ret = sasl_encode( p->sasl_context, buf, len,
 352                 (SASL_CONST char **)&p->buf_out.buf_base,
 353                 (unsigned *)&p->buf_out.buf_size );
 354         if ( ret != SASL_OK ) {
 355                 ber_log_printf( LDAP_DEBUG_ANY, sbiod->sbiod_sb->sb_debug,
 356                         "sb_sasl_write: failed to encode packet: %s\n",
 357                         sasl_errstring( ret, NULL, NULL ) );
 358                 return -1;
 359         }
 360         p->buf_out.buf_end = p->buf_out.buf_size;
 361
 362         ret = ber_pvt_sb_do_write( sbiod, &p->buf_out );
 363         if ( ret <= 0 )
 364                 return ret;
 365         return len;
 366 }
 367
 368 static int
 369 sb_sasl_ctrl( Sockbuf_IO_Desc *sbiod, int opt, void *arg )
 370 {
 371         struct sb_sasl_data     *p;
 372
 373         p = (struct sb_sasl_data *)sbiod->sbiod_pvt;
 374
 375         if ( opt == LBER_SB_OPT_DATA_READY ) {
 376                 if ( p->buf_in.buf_ptr != p->buf_in.buf_end )
 377                         return 1;
 378         }
 379
 380         return LBER_SBIOD_CTRL_NEXT( sbiod, opt, arg );
 381 }
 382
 383 Sockbuf_IO ldap_pvt_sockbuf_io_sasl = {
 384         sb_sasl_setup,          /* sbi_setup */
 385         sb_sasl_remove,         /* sbi_remove */
 386         sb_sasl_ctrl,           /* sbi_ctrl */
 387         sb_sasl_read,           /* sbi_read */
 388         sb_sasl_write,          /* sbi_write */
 389         NULL                    /* sbi_close */
 390 };
 391
 392 int ldap_pvt_sasl_install( Sockbuf *sb, void *ctx_arg )
 393 {
 394 #ifdef NEW_LOGGING
 395         LDAP_LOG ( TRANSPORT, ENTRY, "ldap_pvt_sasl_install\n", 0, 0, 0 );
 396 #else
 397         Debug( LDAP_DEBUG_TRACE, "ldap_pvt_sasl_install\n",
 398                 0, 0, 0 );
 399 #endif
 400
 401         /* don't install the stuff unless security has been negotiated */
 402
 403         if ( !ber_sockbuf_ctrl( sb, LBER_SB_OPT_HAS_IO,
 404                         &ldap_pvt_sockbuf_io_sasl ) )
 405         {
 406 #ifdef LDAP_DEBUG
 407                 ber_sockbuf_add_io( sb, &ber_sockbuf_io_debug,
 408                         LBER_SBIOD_LEVEL_APPLICATION, (void *)"sasl_" );
 409 #endif
 410                 ber_sockbuf_add_io( sb, &ldap_pvt_sockbuf_io_sasl,
 411                         LBER_SBIOD_LEVEL_APPLICATION, ctx_arg );
 412         }
 413
 414         return LDAP_SUCCESS;
 415 }
 416
 417 void ldap_pvt_sasl_remove( Sockbuf *sb )
 418 {
 419         ber_sockbuf_remove_io( sb, &ldap_pvt_sockbuf_io_sasl,
 420                 LBER_SBIOD_LEVEL_APPLICATION );
 421 #ifdef LDAP_DEBUG
 422         ber_sockbuf_remove_io( sb, &ber_sockbuf_io_debug,
 423                 LBER_SBIOD_LEVEL_APPLICATION );
 424 #endif
 425 }
 426
 427 static int
 428 sasl_err2ldap( int saslerr )
 429 {
 430         int rc;
 431
 432         switch (saslerr) {
 433                 case SASL_CONTINUE:
 434                         rc = LDAP_MORE_RESULTS_TO_RETURN;
 435                         break;
 436                 case SASL_INTERACT:
 437                         rc = LDAP_LOCAL_ERROR;
 438                         break;
 439                 case SASL_OK:
 440                         rc = LDAP_SUCCESS;
 441                         break;
 442                 case SASL_FAIL:
 443                         rc = LDAP_LOCAL_ERROR;
 444                         break;
 445                 case SASL_NOMEM:
 446                         rc = LDAP_NO_MEMORY;
 447                         break;
 448                 case SASL_NOMECH:
 449                         rc = LDAP_AUTH_UNKNOWN;
 450                         break;
 451                 case SASL_BADAUTH:
 452                         rc = LDAP_AUTH_UNKNOWN;
 453                         break;
 454                 case SASL_NOAUTHZ:
 455                         rc = LDAP_PARAM_ERROR;
 456                         break;
 457                 case SASL_TOOWEAK:
 458                 case SASL_ENCRYPT:
 459                         rc = LDAP_AUTH_UNKNOWN;
 460                         break;
 461                 default:
 462                         rc = LDAP_LOCAL_ERROR;
 463                         break;
 464         }
 465
 466         assert( rc == LDAP_SUCCESS || LDAP_API_ERROR( rc ) );
 467         return rc;
 468 }
 469
 470 int
 471 ldap_int_sasl_open(
 472         LDAP *ld,
 473         LDAPConn *lc,
 474         const char * host )
 475 {
 476         int rc;
 477         sasl_conn_t *ctx;
 478
 479         assert( lc->lconn_sasl_authctx == NULL );
 480
 481         if ( host == NULL ) {
 482                 ld->ld_errno = LDAP_LOCAL_ERROR;
 483                 return ld->ld_errno;
 484         }
 485
 486 #if SASL_VERSION_MAJOR >= 2
 487         rc = sasl_client_new( "ldap", host, NULL, NULL,
 488                 NULL, 0, &ctx );
 489 #else
 490         rc = sasl_client_new( "ldap", host, NULL,
 491                 SASL_SECURITY_LAYER, &ctx );
 492 #endif
 493
 494         if ( rc != SASL_OK ) {
 495                 ld->ld_errno = sasl_err2ldap( rc );
 496                 return ld->ld_errno;
 497         }
 498
 499 #ifdef NEW_LOGGING
 500         LDAP_LOG ( TRANSPORT, DETAIL1, "ldap_int_sasl_open: host=%s\n",
 501                 host, 0, 0 );
 502 #else
 503         Debug( LDAP_DEBUG_TRACE, "ldap_int_sasl_open: host=%s\n",
 504                 host, 0, 0 );
 505 #endif
 506
 507         lc->lconn_sasl_authctx = ctx;
 508
 509         return LDAP_SUCCESS;
 510 }
 511
 512 int ldap_int_sasl_close( LDAP *ld, LDAPConn *lc )
 513 {
 514         sasl_conn_t *ctx = lc->lconn_sasl_authctx;
 515
 516         if( ctx != NULL ) {
 517                 sasl_dispose( &ctx );
 518                 if ( lc->lconn_sasl_sockctx &&
 519                         lc->lconn_sasl_authctx != lc->lconn_sasl_sockctx ) {
 520                         ctx = lc->lconn_sasl_sockctx;
 521                         sasl_dispose( &ctx );
 522                 }
 523                 lc->lconn_sasl_sockctx = NULL;
 524                 lc->lconn_sasl_authctx = NULL;
 525         }
 526
 527         return LDAP_SUCCESS;
 528 }
 529
 530 int
 531 ldap_int_sasl_bind(
 532         LDAP                    *ld,
 533         const char              *dn,
 534         const char              *mechs,
 535         LDAPControl             **sctrls,
 536         LDAPControl             **cctrls,
 537         unsigned                flags,
 538         LDAP_SASL_INTERACT_PROC *interact,
 539         void * defaults )
 540 {
 541         char *data;
 542         const char *mech = NULL;
 543         const char *pmech = NULL;
 544         int                     saslrc, rc;
 545         sasl_ssf_t              *ssf = NULL;
 546         sasl_conn_t     *ctx, *oldctx = NULL;
 547         sasl_interact_t *prompts = NULL;
 548         unsigned credlen;
 549         struct berval ccred;
 550         ber_socket_t            sd;
 551         void    *ssl;
 552
 553 #ifdef NEW_LOGGING
 554         LDAP_LOG ( TRANSPORT, ARGS, "ldap_int_sasl_bind: %s\n",
 555                 mechs ? mechs : "<null>", 0, 0 );
 556 #else
 557         Debug( LDAP_DEBUG_TRACE, "ldap_int_sasl_bind: %s\n",
 558                 mechs ? mechs : "<null>", 0, 0 );
 559 #endif
 560
 561         /* do a quick !LDAPv3 check... ldap_sasl_bind will do the rest. */
 562         if (ld->ld_version < LDAP_VERSION3) {
 563                 ld->ld_errno = LDAP_NOT_SUPPORTED;
 564                 return ld->ld_errno;
 565         }
 566
 567         ber_sockbuf_ctrl( ld->ld_sb, LBER_SB_OPT_GET_FD, &sd );
 568
 569         if ( sd == AC_SOCKET_INVALID ) {
 570                 /* not connected yet */
 571                 int rc;
 572
 573                 rc = ldap_open_defconn( ld );
 574                 if( rc < 0 ) return ld->ld_errno;
 575
 576                 ber_sockbuf_ctrl( ld->ld_sb, LBER_SB_OPT_GET_FD, &sd );
 577
 578                 if( sd == AC_SOCKET_INVALID ) {
 579                         ld->ld_errno = LDAP_LOCAL_ERROR;
 580                         return ld->ld_errno;
 581                 }
 582         }
 583
 584         oldctx = ld->ld_defconn->lconn_sasl_authctx;
 585
 586         /* If we already have an authentication context, clear it out */
 587         if( oldctx ) {
 588                 if ( oldctx != ld->ld_defconn->lconn_sasl_sockctx ) {
 589                         sasl_dispose( &oldctx );
 590                 }
 591                 ld->ld_defconn->lconn_sasl_authctx = NULL;
 592         }
 593
 594         rc = ldap_int_sasl_open( ld, ld->ld_defconn,
 595                 ld->ld_defconn->lconn_server->lud_host ?
 596                 ld->ld_defconn->lconn_server->lud_host : "localhost" );
 597
 598         if ( rc != LDAP_SUCCESS ) return rc;
 599
 600         ctx = ld->ld_defconn->lconn_sasl_authctx;
 601
 602         /* Check for TLS */
 603         ssl = ldap_pvt_tls_sb_ctx( ld->ld_sb );
 604         if ( ssl ) {
 605                 struct berval authid = { 0, NULL };
 606                 ber_len_t fac;
 607
 608                 fac = ldap_pvt_tls_get_strength( ssl );
 609                 /* failure is OK, we just can't use SASL EXTERNAL */
 610                 (void) ldap_pvt_tls_get_my_dn( ssl, &authid, NULL, 0 );
 611
 612                 (void) ldap_int_sasl_external( ld, ld->ld_defconn, authid.bv_val, fac );
 613                 LDAP_FREE( authid.bv_val );
 614         }
 615
 616         /* Check for local */
 617         if ( ldap_pvt_url_scheme2proto( ld->ld_defconn->lconn_server->lud_scheme ) == LDAP_PROTO_IPC ) {
 618                 char authid[sizeof("uidNumber=4294967295+gidNumber=4294967295,"
 619                         "cn=peercred,cn=external,cn=auth")];
 620                 sprintf( authid, "uidNumber=%d+gidNumber=%d,"
 621                         "cn=peercred,cn=external,cn=auth",
 622                         (int) geteuid(), (int) getegid() );
 623                 (void) ldap_int_sasl_external( ld, ld->ld_defconn, authid, LDAP_PVT_SASL_LOCAL_SSF );
 624         }
 625
 626         /* (re)set security properties */
 627         sasl_setprop( ctx, SASL_SEC_PROPS,
 628                 &ld->ld_options.ldo_sasl_secprops );
 629
 630         ccred.bv_val = NULL;
 631         ccred.bv_len = 0;
 632
 633         do {
 634                 saslrc = sasl_client_start( ctx,
 635                         mechs,
 636 #if SASL_VERSION_MAJOR < 2
 637                         NULL,
 638 #endif
 639                         &prompts,
 640                         (SASL_CONST char **)&ccred.bv_val,
 641                         &credlen,
 642                         &mech );
 643
 644                 if( pmech == NULL && mech != NULL ) {
 645                         pmech = mech;
 646
 647                         if( flags != LDAP_SASL_QUIET ) {
 648                                 fprintf(stderr,
 649                                         "SASL/%s authentication started\n",
 650                                         pmech );
 651                         }
 652                 }
 653
 654                 if( saslrc == SASL_INTERACT ) {
 655                         int res;
 656                         if( !interact ) break;
 657                         res = (interact)( ld, flags, defaults, prompts );
 658
 659                         if( res != LDAP_SUCCESS ) break;
 660                 }
 661         } while ( saslrc == SASL_INTERACT );
 662
 663         ccred.bv_len = credlen;
 664
 665         if ( (saslrc != SASL_OK) && (saslrc != SASL_CONTINUE) ) {
 666                 rc = ld->ld_errno = sasl_err2ldap( saslrc );
 667 #if SASL_VERSION_MAJOR >= 2
 668                 ld->ld_error = (char *)sasl_errdetail( ctx );
 669 #endif
 670                 goto done;
 671         }
 672
 673         do {
 674                 struct berval *scred;
 675                 unsigned credlen;
 676
 677                 scred = NULL;
 678
 679                 rc = ldap_sasl_bind_s( ld, dn, mech, &ccred, sctrls, cctrls, &scred );
 680
 681                 if ( ccred.bv_val != NULL ) {
 682 #if SASL_VERSION_MAJOR < 2
 683                         LDAP_FREE( ccred.bv_val );
 684 #endif
 685                         ccred.bv_val = NULL;
 686                 }
 687
 688                 if ( rc != LDAP_SUCCESS && rc != LDAP_SASL_BIND_IN_PROGRESS ) {
 689                         if( scred && scred->bv_len ) {
 690                                 /* and server provided us with data? */
 691 #ifdef NEW_LOGGING
 692                                 LDAP_LOG ( TRANSPORT, DETAIL1,
 693                                         "ldap_int_sasl_bind: rc=%d sasl=%d len=%ld\n",
 694                                         rc, saslrc, scred->bv_len );
 695 #else
 696                                 Debug( LDAP_DEBUG_TRACE,
 697                                         "ldap_int_sasl_bind: rc=%d sasl=%d len=%ld\n",
 698                                         rc, saslrc, scred->bv_len );
 699 #endif
 700                                 ber_bvfree( scred );
 701                         }
 702                         rc = ld->ld_errno;
 703                         goto done;
 704                 }
 705
 706                 if( rc == LDAP_SUCCESS && saslrc == SASL_OK ) {
 707                         /* we're done, no need to step */
 708                         if( scred && scred->bv_len ) {
 709                                 /* but server provided us with data! */
 710 #ifdef NEW_LOGGING
 711                                 LDAP_LOG ( TRANSPORT, DETAIL1,
 712                                         "ldap_int_sasl_bind: rc=%d sasl=%d len=%ld\n",
 713                                         rc, saslrc, scred->bv_len );
 714 #else
 715                                 Debug( LDAP_DEBUG_TRACE,
 716                                         "ldap_int_sasl_bind: rc=%d sasl=%d len=%ld\n",
 717                                         rc, saslrc, scred->bv_len );
 718 #endif
 719                                 ber_bvfree( scred );
 720                                 rc = ld->ld_errno = LDAP_LOCAL_ERROR;
 721                                 goto done;
 722                         }
 723                         break;
 724                 }
 725
 726                 do {
 727                         saslrc = sasl_client_step( ctx,
 728                                 (scred == NULL) ? NULL : scred->bv_val,
 729                                 (scred == NULL) ? 0 : scred->bv_len,
 730                                 &prompts,
 731                                 (SASL_CONST char **)&ccred.bv_val,
 732                                 &credlen );
 733
 734 #ifdef NEW_LOGGING
 735                                 LDAP_LOG ( TRANSPORT, DETAIL1,
 736                                         "ldap_int_sasl_bind: sasl_client_step: %d\n", saslrc,0,0 );
 737 #else
 738                         Debug( LDAP_DEBUG_TRACE, "sasl_client_step: %d\n",
 739                                 saslrc, 0, 0 );
 740 #endif
 741
 742                         if( saslrc == SASL_INTERACT ) {
 743                                 int res;
 744                                 if( !interact ) break;
 745                                 res = (interact)( ld, flags, defaults, prompts );
 746                                 if( res != LDAP_SUCCESS ) break;
 747                         }
 748                 } while ( saslrc == SASL_INTERACT );
 749
 750                 ccred.bv_len = credlen;
 751                 ber_bvfree( scred );
 752
 753                 if ( (saslrc != SASL_OK) && (saslrc != SASL_CONTINUE) ) {
 754                         ld->ld_errno = sasl_err2ldap( saslrc );
 755 #if SASL_VERSION_MAJOR >= 2
 756                         ld->ld_error = (char *)sasl_errdetail( ctx );
 757 #endif
 758                         rc = ld->ld_errno;
 759                         goto done;
 760                 }
 761         } while ( rc == LDAP_SASL_BIND_IN_PROGRESS );
 762
 763         if ( rc != LDAP_SUCCESS ) goto done;
 764
 765         if ( saslrc != SASL_OK ) {
 766 #if SASL_VERSION_MAJOR >= 2
 767                 ld->ld_error = (char *)sasl_errdetail( ctx );
 768 #endif
 769                 rc = ld->ld_errno = sasl_err2ldap( saslrc );
 770                 goto done;
 771         }
 772
 773         if( flags != LDAP_SASL_QUIET ) {
 774                 saslrc = sasl_getprop( ctx, SASL_USERNAME, (SASL_CONST void **) &data );
 775                 if( saslrc == SASL_OK && data && *data ) {
 776                         fprintf( stderr, "SASL username: %s\n", data );
 777                 }
 778
 779 #if SASL_VERSION_MAJOR < 2
 780                 saslrc = sasl_getprop( ctx, SASL_REALM, (SASL_CONST void **) &data );
 781                 if( saslrc == SASL_OK && data && *data ) {
 782                         fprintf( stderr, "SASL realm: %s\n", data );
 783                 }
 784 #endif
 785         }
 786
 787         saslrc = sasl_getprop( ctx, SASL_SSF, (SASL_CONST void **) &ssf );
 788         if( saslrc == SASL_OK ) {
 789                 if( flags != LDAP_SASL_QUIET ) {
 790                         fprintf( stderr, "SASL SSF: %lu\n",
 791                                 (unsigned long) *ssf );
 792                 }
 793
 794                 if( ssf && *ssf ) {
 795                         if( flags != LDAP_SASL_QUIET ) {
 796                                 fprintf( stderr, "SASL installing layers\n" );
 797                         }
 798                         if ( ld->ld_defconn->lconn_sasl_sockctx ) {
 799                                 oldctx = ld->ld_defconn->lconn_sasl_sockctx;
 800                                 sasl_dispose( &oldctx );
 801                                 ldap_pvt_sasl_remove( ld->ld_sb );
 802                         }
 803                         ldap_pvt_sasl_install( ld->ld_conns->lconn_sb, ctx );
 804                         ld->ld_defconn->lconn_sasl_sockctx = ctx;
 805                 }
 806         }
 807         ld->ld_defconn->lconn_sasl_authctx = ctx;
 808
 809 done:
 810         return rc;
 811 }
 812
 813 int
 814 ldap_int_sasl_external(
 815         LDAP *ld,
 816         LDAPConn *conn,
 817         const char * authid,
 818         ber_len_t ssf )
 819 {
 820         int sc;
 821         sasl_conn_t *ctx;
 822 #if SASL_VERSION_MAJOR < 2
 823         sasl_external_properties_t extprops;
 824 #endif
 825
 826         ctx = conn->lconn_sasl_authctx;
 827
 828         if ( ctx == NULL ) {
 829                 return LDAP_LOCAL_ERROR;
 830         }
 831
 832 #if SASL_VERSION_MAJOR >= 2
 833         sc = sasl_setprop( ctx, SASL_SSF_EXTERNAL, &ssf );
 834         if ( sc == SASL_OK )
 835                 sc = sasl_setprop( ctx, SASL_AUTH_EXTERNAL, authid );
 836 #else
 837         memset( &extprops, '\0', sizeof(extprops) );
 838         extprops.ssf = ssf;
 839         extprops.auth_id = (char *) authid;
 840
 841         sc = sasl_setprop( ctx, SASL_SSF_EXTERNAL,
 842                 (void *) &extprops );
 843 #endif
 844
 845         if ( sc != SASL_OK ) {
 846                 return LDAP_LOCAL_ERROR;
 847         }
 848
 849         return LDAP_SUCCESS;
 850 }
 851
 852
 853 int ldap_pvt_sasl_secprops(
 854         const char *in,
 855         sasl_security_properties_t *secprops )
 856 {
 857         int i;
 858         char **props = ldap_str2charray( in, "," );
 859         unsigned sflags = 0;
 860         int got_sflags = 0;
 861         sasl_ssf_t max_ssf = 0;
 862         int got_max_ssf = 0;
 863         sasl_ssf_t min_ssf = 0;
 864         int got_min_ssf = 0;
 865         unsigned maxbufsize = 0;
 866         int got_maxbufsize = 0;
 867
 868         if( props == NULL || secprops == NULL ) {
 869                 return LDAP_PARAM_ERROR;
 870         }
 871
 872         for( i=0; props[i]; i++ ) {
 873                 if( !strcasecmp(props[i], "none") ) {
 874                         got_sflags++;
 875
 876                 } else if( !strcasecmp(props[i], "noplain") ) {
 877                         got_sflags++;
 878                         sflags |= SASL_SEC_NOPLAINTEXT;
 879
 880                 } else if( !strcasecmp(props[i], "noactive") ) {
 881                         got_sflags++;
 882                         sflags |= SASL_SEC_NOACTIVE;
 883
 884                 } else if( !strcasecmp(props[i], "nodict") ) {
 885                         got_sflags++;
 886                         sflags |= SASL_SEC_NODICTIONARY;
 887
 888                 } else if( !strcasecmp(props[i], "forwardsec") ) {
 889                         got_sflags++;
 890                         sflags |= SASL_SEC_FORWARD_SECRECY;
 891
 892                 } else if( !strcasecmp(props[i], "noanonymous")) {
 893                         got_sflags++;
 894                         sflags |= SASL_SEC_NOANONYMOUS;
 895
 896                 } else if( !strcasecmp(props[i], "passcred") ) {
 897                         got_sflags++;
 898                         sflags |= SASL_SEC_PASS_CREDENTIALS;
 899
 900                 } else if( !strncasecmp(props[i],
 901                         "minssf=", sizeof("minssf")) )
 902                 {
 903                         if( isdigit( (unsigned char) props[i][sizeof("minssf")] ) ) {
 904                                 got_min_ssf++;
 905                                 min_ssf = atoi( &props[i][sizeof("minssf")] );
 906                         } else {
 907                                 return LDAP_NOT_SUPPORTED;
 908                         }
 909
 910                 } else if( !strncasecmp(props[i],
 911                         "maxssf=", sizeof("maxssf")) )
 912                 {
 913                         if( isdigit( (unsigned char) props[i][sizeof("maxssf")] ) ) {
 914                                 got_max_ssf++;
 915                                 max_ssf = atoi( &props[i][sizeof("maxssf")] );
 916                         } else {
 917                                 return LDAP_NOT_SUPPORTED;
 918                         }
 919
 920                 } else if( !strncasecmp(props[i],
 921                         "maxbufsize=", sizeof("maxbufsize")) )
 922                 {
 923                         if( isdigit( (unsigned char) props[i][sizeof("maxbufsize")] ) ) {
 924                                 got_maxbufsize++;
 925                                 maxbufsize = atoi( &props[i][sizeof("maxbufsize")] );
 926                         } else {
 927                                 return LDAP_NOT_SUPPORTED;
 928                         }
 929
 930                         if( maxbufsize && (( maxbufsize < SASL_MIN_BUFF_SIZE )
 931                                 || (maxbufsize > SASL_MAX_BUFF_SIZE )))
 932                         {
 933                                 /* bad maxbufsize */
 934                                 return LDAP_PARAM_ERROR;
 935                         }
 936
 937                 } else {
 938                         return LDAP_NOT_SUPPORTED;
 939                 }
 940         }
 941
 942         if(got_sflags) {
 943                 secprops->security_flags = sflags;
 944         }
 945         if(got_min_ssf) {
 946                 secprops->min_ssf = min_ssf;
 947         }
 948         if(got_max_ssf) {
 949                 secprops->max_ssf = max_ssf;
 950         }
 951         if(got_maxbufsize) {
 952                 secprops->maxbufsize = maxbufsize;
 953         }
 954
 955         ldap_charray_free( props );
 956         return LDAP_SUCCESS;
 957 }
 958
 959 int
 960 ldap_int_sasl_config( struct ldapoptions *lo, int option, const char *arg )
 961 {
 962         int rc;
 963
 964         switch( option ) {
 965         case LDAP_OPT_X_SASL_SECPROPS:
 966                 rc = ldap_pvt_sasl_secprops( arg, &lo->ldo_sasl_secprops );
 967                 if( rc == LDAP_SUCCESS ) return 0;
 968         }
 969
 970         return -1;
 971 }
 972
 973 int
 974 ldap_int_sasl_get_option( LDAP *ld, int option, void *arg )
 975 {
 976         if ( ld == NULL )
 977                 return -1;
 978
 979         switch ( option ) {
 980                 case LDAP_OPT_X_SASL_MECH: {
 981                         *(char **)arg = ld->ld_options.ldo_def_sasl_mech
 982                                 ? LDAP_STRDUP( ld->ld_options.ldo_def_sasl_mech ) : NULL;
 983                 } break;
 984                 case LDAP_OPT_X_SASL_REALM: {
 985                         *(char **)arg = ld->ld_options.ldo_def_sasl_realm
 986                                 ? LDAP_STRDUP( ld->ld_options.ldo_def_sasl_realm ) : NULL;
 987                 } break;
 988                 case LDAP_OPT_X_SASL_AUTHCID: {
 989                         *(char **)arg = ld->ld_options.ldo_def_sasl_authcid
 990                                 ? LDAP_STRDUP( ld->ld_options.ldo_def_sasl_authcid ) : NULL;
 991                 } break;
 992                 case LDAP_OPT_X_SASL_AUTHZID: {
 993                         *(char **)arg = ld->ld_options.ldo_def_sasl_authzid
 994                                 ? LDAP_STRDUP( ld->ld_options.ldo_def_sasl_authzid ) : NULL;
 995                 } break;
 996
 997                 case LDAP_OPT_X_SASL_SSF: {
 998                         int sc;
 999                         sasl_ssf_t      *ssf;
1000                         sasl_conn_t *ctx;
1001
1002                         if( ld->ld_defconn == NULL ) {
1003                                 return -1;
1004                         }
1005
1006                         ctx = ld->ld_defconn->lconn_sasl_sockctx;
1007
1008                         if ( ctx == NULL ) {
1009                                 return -1;
1010                         }
1011
1012                         sc = sasl_getprop( ctx, SASL_SSF,
1013                                 (SASL_CONST void **) &ssf );
1014
1015                         if ( sc != SASL_OK ) {
1016                                 return -1;
1017                         }
1018
1019                         *(ber_len_t *)arg = *ssf;
1020                 } break;
1021
1022                 case LDAP_OPT_X_SASL_SSF_EXTERNAL:
1023                         /* this option is write only */
1024                         return -1;
1025
1026                 case LDAP_OPT_X_SASL_SSF_MIN:
1027                         *(ber_len_t *)arg = ld->ld_options.ldo_sasl_secprops.min_ssf;
1028                         break;
1029                 case LDAP_OPT_X_SASL_SSF_MAX:
1030                         *(ber_len_t *)arg = ld->ld_options.ldo_sasl_secprops.max_ssf;
1031                         break;
1032                 case LDAP_OPT_X_SASL_MAXBUFSIZE:
1033                         *(ber_len_t *)arg = ld->ld_options.ldo_sasl_secprops.maxbufsize;
1034                         break;
1035
1036                 case LDAP_OPT_X_SASL_SECPROPS:
1037                         /* this option is write only */
1038                         return -1;
1039
1040                 default:
1041                         return -1;
1042         }
1043         return 0;
1044 }
1045
1046 int
1047 ldap_int_sasl_set_option( LDAP *ld, int option, void *arg )
1048 {
1049         if ( ld == NULL )
1050                 return -1;
1051
1052         switch ( option ) {
1053         case LDAP_OPT_X_SASL_SSF:
1054                 /* This option is read-only */
1055                 return -1;
1056
1057         case LDAP_OPT_X_SASL_SSF_EXTERNAL: {
1058                 int sc;
1059 #if SASL_VERSION_MAJOR < 2
1060                 sasl_external_properties_t extprops;
1061 #endif
1062                 sasl_conn_t *ctx;
1063
1064                 if( ld->ld_defconn == NULL ) {
1065                         return -1;
1066                 }
1067
1068                 ctx = ld->ld_defconn->lconn_sasl_authctx;
1069
1070                 if ( ctx == NULL ) {
1071                         return -1;
1072                 }
1073
1074 #if SASL_VERSION_MAJOR >= 2
1075                 sc = sasl_setprop( ctx, SASL_SSF_EXTERNAL, arg);
1076 #else
1077                 memset(&extprops, 0L, sizeof(extprops));
1078
1079                 extprops.ssf = * (ber_len_t *) arg;
1080
1081                 sc = sasl_setprop( ctx, SASL_SSF_EXTERNAL,
1082                         (void *) &extprops );
1083 #endif
1084
1085                 if ( sc != SASL_OK ) {
1086                         return -1;
1087                 }
1088                 } break;
1089
1090         case LDAP_OPT_X_SASL_SSF_MIN:
1091                 ld->ld_options.ldo_sasl_secprops.min_ssf = *(ber_len_t *)arg;
1092                 break;
1093         case LDAP_OPT_X_SASL_SSF_MAX:
1094                 ld->ld_options.ldo_sasl_secprops.max_ssf = *(ber_len_t *)arg;
1095                 break;
1096         case LDAP_OPT_X_SASL_MAXBUFSIZE:
1097                 ld->ld_options.ldo_sasl_secprops.maxbufsize = *(ber_len_t *)arg;
1098                 break;
1099
1100         case LDAP_OPT_X_SASL_SECPROPS: {
1101                 int sc;
1102                 sc = ldap_pvt_sasl_secprops( (char *) arg,
1103                         &ld->ld_options.ldo_sasl_secprops );
1104
1105                 return sc == LDAP_SUCCESS ? 0 : -1;
1106                 }
1107
1108         default:
1109                 return -1;
1110         }
1111         return 0;
1112 }
1113
1114 #ifdef LDAP_R_COMPILE
1115 #define LDAP_DEBUG_R_SASL
1116 void *ldap_pvt_sasl_mutex_new(void)
1117 {
1118         ldap_pvt_thread_mutex_t *mutex;
1119
1120         mutex = (ldap_pvt_thread_mutex_t *) LDAP_MALLOC(
1121                 sizeof(ldap_pvt_thread_mutex_t) );
1122
1123         if ( ldap_pvt_thread_mutex_init( mutex ) == 0 ) {
1124                 return mutex;
1125         }
1126 #ifndef LDAP_DEBUG_R_SASL
1127         assert( 0 );
1128 #endif /* !LDAP_DEBUG_R_SASL */
1129         return NULL;
1130 }
1131
1132 int ldap_pvt_sasl_mutex_lock(void *mutex)
1133 {
1134 #ifdef LDAP_DEBUG_R_SASL
1135         if ( mutex == NULL ) {
1136                 return SASL_OK;
1137         }
1138 #else /* !LDAP_DEBUG_R_SASL */
1139         assert( mutex );
1140 #endif /* !LDAP_DEBUG_R_SASL */
1141         return ldap_pvt_thread_mutex_lock( (ldap_pvt_thread_mutex_t *)mutex )
1142                 ? SASL_FAIL : SASL_OK;
1143 }
1144
1145 int ldap_pvt_sasl_mutex_unlock(void *mutex)
1146 {
1147 #ifdef LDAP_DEBUG_R_SASL
1148         if ( mutex == NULL ) {
1149                 return SASL_OK;
1150         }
1151 #else /* !LDAP_DEBUG_R_SASL */
1152         assert( mutex );
1153 #endif /* !LDAP_DEBUG_R_SASL */
1154         return ldap_pvt_thread_mutex_unlock( (ldap_pvt_thread_mutex_t *)mutex )
1155                 ? SASL_FAIL : SASL_OK;
1156 }
1157
1158 void ldap_pvt_sasl_mutex_dispose(void *mutex)
1159 {
1160 #ifdef LDAP_DEBUG_R_SASL
1161         if ( mutex == NULL ) {
1162                 return;
1163         }
1164 #else /* !LDAP_DEBUG_R_SASL */
1165         assert( mutex );
1166 #endif /* !LDAP_DEBUG_R_SASL */
1167         (void) ldap_pvt_thread_mutex_destroy( (ldap_pvt_thread_mutex_t *)mutex );
1168         LDAP_FREE( mutex );
1169 }
1170 #endif
1171
1172 #else
1173 int ldap_int_sasl_init( void )
1174 { return LDAP_SUCCESS; }
1175
1176 int ldap_int_sasl_close( LDAP *ld, LDAPConn *lc )
1177 { return LDAP_SUCCESS; }
1178
1179 int
1180 ldap_int_sasl_bind(
1181         LDAP                    *ld,
1182         const char              *dn,
1183         const char              *mechs,
1184         LDAPControl             **sctrls,
1185         LDAPControl             **cctrls,
1186         unsigned                flags,
1187         LDAP_SASL_INTERACT_PROC *interact,
1188         void * defaults )
1189 { return LDAP_NOT_SUPPORTED; }
1190
1191 int
1192 ldap_int_sasl_external(
1193         LDAP *ld,
1194         LDAPConn *conn,
1195         const char * authid,
1196         ber_len_t ssf )
1197 { return LDAP_SUCCESS; }
1198
1199 #endif /* HAVE_CYRUS_SASL */