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

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