]> git.sur5r.net Git - openldap/blobdiff - servers/slapd/sasl.c
add logs; fix bug in group/dn selection logic
[openldap] / servers / slapd / sasl.c
index 4613cee59fab6055dc39701026b18ce892a61fea..1daf41355611b9b3337ab1d22a14377a5a927f69 100644 (file)
@@ -1,7 +1,7 @@
 /* $OpenLDAP$ */
 /* This work is part of OpenLDAP Software <http://www.openldap.org/>.
  *
- * Copyright 1998-2003 The OpenLDAP Foundation.
+ * Copyright 1998-2004 The OpenLDAP Foundation.
  * All rights reserved.
  *
  * Redistribution and use in source and binary forms, with or without
 #  define      SASL_CONST
 # endif
 
-static sasl_security_properties_t sasl_secprops;
-
 #define SASL_VERSION_FULL      ((SASL_VERSION_MAJOR << 16) |\
        (SASL_VERSION_MINOR << 8) | SASL_VERSION_STEP)
 
-#endif /* HAVE_CYRUS_SASL */
+static sasl_security_properties_t sasl_secprops;
+#elif defined( SLAP_BUILTIN_SASL )
+/*
+ * built-in SASL implementation
+ *     only supports EXTERNAL
+ */
+typedef struct sasl_ctx {
+       slap_ssf_t sc_external_ssf;
+       struct berval sc_external_id;
+} SASL_CTX;
+
+#endif
 
 #include "ldap_pvt.h"
 #include "lber_pvt.h"
 #include <lutil.h>
 
+static struct berval ext_bv = BER_BVC( "EXTERNAL" );
+
 int slap_sasl_config( int cargc, char **cargv, char *line,
        const char *fname, int lineno )
 {
                /* set SASL proxy authorization policy */
-               if ( strcasecmp( cargv[0], "sasl-authz-policy" ) == 0 ) {
+               if ( !strcasecmp( cargv[0], "authz-policy" ) ||
+                       !strcasecmp( cargv[0], "sasl-authz-policy" ))
+               {
                        if ( cargc != 2 ) {
 #ifdef NEW_LOGGING
                                LDAP_LOG( CONFIG, CRIT,
                                        "%s: line %d: missing policy in"
-                                       " \"sasl-authz-policy <policy>\" line\n",
-                                       fname, lineno, 0 );
+                                       " \"%s <policy>\" line\n",
+                                   cargv[0], fname, lineno );
 #else
                                Debug( LDAP_DEBUG_ANY,
                                        "%s: line %d: missing policy in"
-                                       " \"sasl-authz-policy <policy>\" line\n",
-                                   fname, lineno, 0 );
+                                       " \"%s <policy>\" line\n",
+                                   cargv[0], fname, lineno );
 #endif
 
                                return( 1 );
                        }
                        if ( slap_sasl_setpolicy( cargv[1] ) ) {
 #ifdef NEW_LOGGING
-                               LDAP_LOG( CONFIG, CRIT,
-                                          "%s: line %d: unable "
-                                          "to parse value \"%s\" "
-                                          "in \"sasl-authz-policy "
-                                          "<policy>\" line.\n",
-                                          fname, lineno, cargv[1] );
+                               LDAP_LOG( CONFIG, CRIT, "%s: line %d: "
+                                       "unable to parse value \"%s\" in \"authz-policy "
+                                       "<policy>\" line.\n",
+                                       fname, lineno, cargv[1] );
 #else
-                               Debug( LDAP_DEBUG_ANY,
-                                       "%s: line %d: unable "
-                                       "to parse value \"%s\" "
-                                       "in \"sasl-authz-policy "
-                                       "<policy>\" line\n",
-                                       fname, lineno, cargv[1] );
+                               Debug( LDAP_DEBUG_ANY, "%s: line %d: "
+                                       "unable to parse value \"%s\" in \"authz-policy "
+                                       "<policy>\" line.\n",
+                                       fname, lineno, cargv[1] );
 #endif
                                return( 1 );
                        }
 
-               } else if ( !strcasecmp( cargv[0], "sasl-regexp" ) 
-                       || !strcasecmp( cargv[0], "saslregexp" ) )
+               } else if ( !strcasecmp( cargv[0], "authz-regexp" ) || 
+                       !strcasecmp( cargv[0], "sasl-regexp" ) ||
+                       !strcasecmp( cargv[0], "saslregexp" ) )
                {
                        int rc;
                        if ( cargc != 3 ) {
 #ifdef NEW_LOGGING
                                LDAP_LOG( CONFIG, CRIT,
                                        "%s: line %d: need 2 args in "
-                                       "\"saslregexp <match> <replace>\"\n",
+                                       "\"authz-regexp <match> <replace>\"\n",
                                        fname, lineno, 0 );
 #else
                                Debug( LDAP_DEBUG_ANY, 
                                        "%s: line %d: need 2 args in "
-                                       "\"saslregexp <match> <replace>\"\n",
+                                       "\"authz-regexp <match> <replace>\"\n",
                                        fname, lineno, 0 );
 #endif
 
@@ -307,7 +317,7 @@ slap_sasl_log(
 
 #if SASL_VERSION_MAJOR >= 2
 static const char *slap_propnames[] = {
-       "*slapConn", "*authcDN", "*authzDN", NULL };
+       "*slapConn", "*slapAuthcDN", "*slapAuthzDN", NULL };
 
 static Filter generic_filter = { LDAP_FILTER_PRESENT };
 static struct berval generic_filterstr = BER_BVC("(objectclass=*)");
@@ -315,15 +325,15 @@ static struct berval generic_filterstr = BER_BVC("(objectclass=*)");
 #define        PROP_CONN       0
 #define        PROP_AUTHC      1
 #define        PROP_AUTHZ      2
+#define        PROP_COUNT      3       /* Number of properties we used */
 
 typedef struct lookup_info {
-       int last;
        int flags;
        const struct propval *list;
        sasl_server_params_t *sparams;
 } lookup_info;
 
-static slap_response sasl_ap_lookup, sasl_cb_checkpass;
+static slap_response sasl_ap_lookup;
 
 static int
 sasl_ap_lookup( Operation *op, SlapReply *rs )
@@ -338,11 +348,16 @@ sasl_ap_lookup( Operation *op, SlapReply *rs )
 
        if (rs->sr_type != REP_SEARCH) return 0;
 
-       for( i = 0; i < sl->last; i++ ) {
+       for( i = 0; sl->list[i].name; i++ ) {
                const char *name = sl->list[i].name;
 
                if ( name[0] == '*' ) {
                        if ( sl->flags & SASL_AUXPROP_AUTHZID ) continue;
+                       /* Skip our private properties */
+                       if ( !strcmp( name, slap_propnames[0] )) {
+                               i += PROP_COUNT-1;
+                               continue;
+                       }
                        name++;
                } else if ( !(sl->flags & SASL_AUXPROP_AUTHZID ) )
                        continue;
@@ -397,23 +412,21 @@ slap_auxprop_lookup(
        sl.flags = flags;
 
        /* Find our DN and conn first */
-       for( i = 0, sl.last = 0; sl.list[i].name; i++ ) {
+       for( i = 0; sl.list[i].name; i++ ) {
                if ( sl.list[i].name[0] == '*' ) {
                        if ( !strcmp( sl.list[i].name, slap_propnames[PROP_CONN] ) ) {
                                if ( sl.list[i].values && sl.list[i].values[0] )
                                        AC_MEMCPY( &conn, sl.list[i].values[0], sizeof( conn ) );
-                               if ( !sl.last ) sl.last = i;
+                               continue;
                        }
                        if ( (flags & SASL_AUXPROP_AUTHZID) &&
                                !strcmp( sl.list[i].name, slap_propnames[PROP_AUTHZ] ) ) {
 
                                if ( sl.list[i].values && sl.list[i].values[0] )
                                        AC_MEMCPY( &op.o_req_ndn, sl.list[i].values[0], sizeof( struct berval ) );
-                               if ( !sl.last ) sl.last = i;
                                break;
                        }
                        if ( !strcmp( sl.list[i].name, slap_propnames[PROP_AUTHC] ) ) {
-                               if ( !sl.last ) sl.last = i;
                                if ( sl.list[i].values && sl.list[i].values[0] ) {
                                        AC_MEMCPY( &op.o_req_ndn, sl.list[i].values[0], sizeof( struct berval ) );
                                        if ( !(flags & SASL_AUXPROP_AUTHZID) )
@@ -424,11 +437,16 @@ slap_auxprop_lookup(
        }
 
        /* Now see what else needs to be fetched */
-       for( i = 0; i < sl.last; i++ ) {
+       for( i = 0; sl.list[i].name; i++ ) {
                const char *name = sl.list[i].name;
 
                if ( name[0] == '*' ) {
                        if ( flags & SASL_AUXPROP_AUTHZID ) continue;
+                       /* Skip our private properties */
+                       if ( !strcmp( name, slap_propnames[0] )) {
+                               i += PROP_COUNT-1;
+                               continue;
+                       }
                        name++;
                } else if ( !(flags & SASL_AUXPROP_AUTHZID ) )
                        continue;
@@ -437,6 +455,7 @@ slap_auxprop_lookup(
                        if ( !(flags & SASL_AUXPROP_OVERRIDE) ) continue;
                }
                doit = 1;
+               break;
        }
 
        if (doit) {
@@ -535,8 +554,7 @@ slap_auxprop_store(
                for (j=0; j<pr[i].nvalues; j++) {
                        ber_str2bv( pr[i].values[j], 0, 1, &mod->sml_values[j]);
                }
-               mod->sml_values[j].bv_val = NULL;
-               mod->sml_values[j].bv_len = 0;
+               BER_BVZERO( &mod->sml_values[j] );
                mod->sml_nvalues = NULL;
                mod->sml_desc = NULL;
                *modtail = mod;
@@ -597,7 +615,7 @@ slap_auxprop_init(
        sasl_auxprop_plug_t **plug,
        const char *plugname)
 {
-       if ( !out_version | !plug ) return SASL_BADPARAM;
+       if ( !out_version || !plug ) return SASL_BADPARAM;
 
        if ( max_version < SASL_AUXPROP_PLUG_VERSION ) return SASL_BADVERS;
 
@@ -606,118 +624,11 @@ slap_auxprop_init(
        return SASL_OK;
 }
 
-typedef struct checkpass_info {
-       int rc;
-       struct berval cred;
-} checkpass_info;
-
-static int
-sasl_cb_checkpass( Operation *op, SlapReply *rs )
-{
-       slap_callback *tmp = op->o_callback;
-       checkpass_info *ci = tmp->sc_private;
-       Attribute *a;
-       struct berval *bv;
-       
-       if (rs->sr_type != REP_SEARCH) return 0;
-
-       ci->rc = SASL_NOVERIFY;
-
-       a = attr_find( rs->sr_entry->e_attrs, slap_schema.si_ad_userPassword );
-       if ( !a ) return 0;
-       if ( ! access_allowed( op, rs->sr_entry, slap_schema.si_ad_userPassword,
-               NULL, ACL_AUTH, NULL ) ) return 0;
-
-       for ( bv = a->a_vals; bv->bv_val != NULL; bv++ ) {
-               if ( !lutil_passwd( bv, &ci->cred, NULL, &rs->sr_text ) ) {
-                       ci->rc = SASL_OK;
-                       break;
-               }
-       }
-       return 0;
-}
-
-static int
-slap_sasl_checkpass(
-       sasl_conn_t *sconn,
-       void *context,
-       const char *username,
-       const char *pass,
-       unsigned passlen,
-       struct propctx *propctx)
-{
-       Connection *conn = (Connection *)context;
-       Operation op = {0};
-       int rc;
-       checkpass_info ci;
-
-       ci.rc = SASL_NOUSER;
-
-       /* SASL will fallback to its own mechanisms if we don't
-        * find an answer here.
-        */
-
-       rc = slap_sasl_getdn( conn, NULL, (char *)username, 0, NULL, &op.o_req_ndn,
-               SLAP_GETDN_AUTHCID );
-       if ( rc != LDAP_SUCCESS ) {
-               sasl_seterror( sconn, 0, ldap_err2string( rc ) );
-               return SASL_NOUSER;
-       }
-
-       if ( op.o_req_ndn.bv_len == 0 ) {
-               sasl_seterror( sconn, 0,
-                       "No password is associated with the Root DSE" );
-               if ( op.o_req_ndn.bv_val != NULL ) {
-                       ch_free( op.o_req_ndn.bv_val );
-               }
-               return SASL_NOUSER;
-       }
-
-       op.o_bd = select_backend( &op.o_req_ndn, 0, 1 );
-       if ( op.o_bd && op.o_bd->be_search ) {
-               slap_callback cb = { NULL, sasl_cb_checkpass, NULL, NULL };
-               SlapReply rs = {REP_RESULT};
-
-               ci.cred.bv_val = (char *)pass;
-               ci.cred.bv_len = passlen;
-
-               cb.sc_private = &ci;
-               op.o_tag = LDAP_REQ_SEARCH;
-               op.o_protocol = LDAP_VERSION3;
-               op.o_ndn = conn->c_ndn;
-               op.o_callback = &cb;
-               op.o_time = slap_get_time();
-               op.o_do_not_cache = 1;
-               op.o_is_auth_check = 1;
-               op.o_threadctx = conn->c_sasl_bindop->o_threadctx;
-               op.o_tmpmemctx = conn->c_sasl_bindop->o_tmpmemctx;
-               op.o_tmpmfuncs = conn->c_sasl_bindop->o_tmpmfuncs;
-               op.o_conn = conn;
-               op.o_connid = conn->c_connid;
-               op.o_req_dn = op.o_req_ndn;
-               op.ors_scope = LDAP_SCOPE_BASE;
-               op.ors_deref = LDAP_DEREF_NEVER;
-               op.ors_slimit = 1;
-               op.ors_filter = &generic_filter;
-               op.ors_filterstr = generic_filterstr;
-
-               op.o_bd->be_search( &op, &rs );
-       }
-       if ( ci.rc != SASL_OK ) {
-               sasl_seterror( sconn, 0,
-                       ldap_err2string( LDAP_INVALID_CREDENTIALS ) );
-       }
-
-       ch_free( op.o_req_ndn.bv_val );
-
-       return ci.rc;
-}
-
 /* Convert a SASL authcid or authzid into a DN. Store the DN in an
  * auxiliary property, so that we can refer to it in sasl_authorize
  * without interfering with anything else. Also, the SASL username
  * buffer is constrained to 256 characters, and our DNs could be
- * much longer (totally arbitrary length)...
+ * much longer (SLAP_LDAPDN_MAXLEN, currently set to 8192)
  */
 static int
 slap_sasl_canonicalize(
@@ -737,6 +648,7 @@ slap_sasl_canonicalize(
        struct berval dn;
        int rc, which;
        const char *names[2];
+       struct berval   bvin;
 
        *out_len = 0;
 
@@ -759,6 +671,14 @@ slap_sasl_canonicalize(
        if ( inlen > out_max )
                inlen = out_max-1;
 
+       /* This is a Simple Bind using SPASSWD. That means the in-directory
+        * userPassword of the Binding user already points at SASL, so it
+        * cannot be used to actually satisfy a password comparison. Just
+        * ignore it, some other mech will process it.
+        */
+       if ( !conn->c_sasl_bindop ||
+               conn->c_sasl_bindop->orb_method != LDAP_AUTH_SASL ) goto done;
+
        /* See if we need to add request, can only do it once */
        prop_getnames( props, slap_propnames, auxvals );
        if ( !auxvals[0].name )
@@ -804,7 +724,9 @@ slap_sasl_canonicalize(
                if ( !rc ) goto done;
        }
 
-       rc = slap_sasl_getdn( conn, NULL, (char *)in, inlen, (char *)user_realm, &dn,
+       bvin.bv_val = (char *)in;
+       bvin.bv_len = inlen;
+       rc = slap_sasl_getdn( conn, NULL, &bvin, (char *)user_realm, &dn,
                (flags & SASL_CU_AUTHID) ? SLAP_GETDN_AUTHCID : SLAP_GETDN_AUTHZID );
        if ( rc != LDAP_SUCCESS ) {
                sasl_seterror( sconn, 0, ldap_err2string( rc ) );
@@ -853,6 +775,10 @@ slap_sasl_authorize(
        struct berval authcDN, authzDN;
        int rc;
 
+       /* Simple Binds don't support proxy authorization, ignore it */
+       if ( !conn->c_sasl_bindop ||
+               conn->c_sasl_bindop->orb_method != LDAP_AUTH_SASL ) return SASL_OK;
+
 #ifdef NEW_LOGGING
        LDAP_LOG( TRANSPORT, ENTRY, 
                "slap_sasl_authorize: conn %d authcid=\"%s\" authzid=\"%s\"\n",
@@ -864,13 +790,18 @@ slap_sasl_authorize(
 #endif
        if ( conn->c_sasl_dn.bv_val ) {
                ch_free( conn->c_sasl_dn.bv_val );
-               conn->c_sasl_dn.bv_val = NULL;
-               conn->c_sasl_dn.bv_len = 0;
+               BER_BVZERO( &conn->c_sasl_dn );
        }
 
        /* Skip PROP_CONN */
        prop_getnames( props, slap_propnames+1, auxvals );
        
+       /* Should not happen */
+       if ( !auxvals[0].values ) {
+               sasl_seterror( sconn, 0, "invalid authcid" );
+               return SASL_NOAUTHZ;
+       }
+
        AC_MEMCPY( &authcDN, auxvals[0].values[0], sizeof(authcDN) );
 
        /* Nothing to do if no authzID was given */
@@ -933,12 +864,12 @@ slap_sasl_authorize(
        int rc;
        Connection *conn = context;
        char *realm;
+       struct berval   bvauthcid, bvauthzid;
 
        *user = NULL;
        if ( conn->c_sasl_dn.bv_val ) {
                ch_free( conn->c_sasl_dn.bv_val );
-               conn->c_sasl_dn.bv_val = NULL;
-               conn->c_sasl_dn.bv_len = 0;
+               BER_BVZERO( &conn->c_sasl_dn );
        }
 
 #ifdef NEW_LOGGING
@@ -970,13 +901,15 @@ slap_sasl_authorize(
 
        /* Convert the identities to DN's. If no authzid was given, client will
           be bound as the DN matching their username */
-       rc = slap_sasl_getdn( conn, NULL, (char *)authcid, 0, realm,
+       bvauthcid.bv_val = authcid;
+       bvauthcid.bv_len = authcid ? strlen( authcid ) : 0;
+       rc = slap_sasl_getdn( conn, NULL, &bvauthcid, realm,
                &authcDN, SLAP_GETDN_AUTHCID );
        if( rc != LDAP_SUCCESS ) {
                *errstr = ldap_err2string( rc );
                return SASL_NOAUTHZ;
        }
-       if( ( authzid == NULL ) || !strcmp( authcid,authzid ) ) {
+       if( ( authzid == NULL ) || !strcmp( authcid, authzid ) ) {
 #ifdef NEW_LOGGING
                LDAP_LOG( TRANSPORT, ENTRY, 
                        "slap_sasl_authorize: conn %d  Using authcDN=%s\n",
@@ -989,7 +922,10 @@ slap_sasl_authorize(
                conn->c_sasl_dn = authcDN;
                goto ok;
        }
-       rc = slap_sasl_getdn( conn, NULL, (char *)authzid, 0, realm,
+
+       bvauthzid.bv_val = authzid;
+       bvauthzid.bv_len = authzid ? strlen( authzid ) : 0;
+       rc = slap_sasl_getdn( conn, NULL, &bvauthzid, realm,
                &authzDN, SLAP_GETDN_AUTHZID );
        if( rc != LDAP_SUCCESS ) {
                ch_free( authcDN.bv_val );
@@ -1098,7 +1034,8 @@ int slap_sasl_init( void )
 
        sasl_version( NULL, &rc );
        if ( ((rc >> 16) != ((SASL_VERSION_MAJOR << 8)|SASL_VERSION_MINOR)) ||
-               (rc & 0xffff) < SASL_VERSION_STEP) {
+               (rc & 0xffff) < SASL_VERSION_STEP)
+       {
                char version[sizeof("xxx.xxx.xxxxx")];
                sprintf( version, "%u.%d.%d", (unsigned)rc >> 24, (rc >> 16) & 0xff,
                        rc & 0xffff );
@@ -1163,7 +1100,6 @@ int slap_sasl_init( void )
                0, 0, 0 );
 #endif
 
-
        /* default security properties */
        memset( &sasl_secprops, '\0', sizeof(sasl_secprops) );
        sasl_secprops.max_ssf = INT_MAX;
@@ -1187,15 +1123,17 @@ int slap_sasl_destroy( void )
 
 int slap_sasl_open( Connection *conn, int reopen )
 {
-       int cb, sc = LDAP_SUCCESS;
-#if SASL_VERSION_MAJOR >= 2
-       char *ipremoteport = NULL, *iplocalport = NULL;
-#endif
-
+       int sc = LDAP_SUCCESS;
 #ifdef HAVE_CYRUS_SASL
+       int cb;
+
        sasl_conn_t *ctx = NULL;
        sasl_callback_t *session_callbacks;
 
+#if SASL_VERSION_MAJOR >= 2
+       char *ipremoteport = NULL, *iplocalport = NULL;
+#endif
+
        assert( conn->c_sasl_authctx == NULL );
 
        if ( !reopen ) {
@@ -1231,11 +1169,6 @@ int slap_sasl_open( Connection *conn, int reopen )
                session_callbacks[cb].id = SASL_CB_CANON_USER;
                session_callbacks[cb].proc = &slap_sasl_canonicalize;
                session_callbacks[cb++].context = conn;
-
-               /* XXXX: this should be conditional */
-               session_callbacks[cb].id = SASL_CB_SERVER_USERDB_CHECKPASS;
-               session_callbacks[cb].proc = &slap_sasl_checkpass;
-               session_callbacks[cb++].context = conn;
 #endif
 
                session_callbacks[cb].id = SASL_CB_LIST_END;
@@ -1325,14 +1258,25 @@ int slap_sasl_open( Connection *conn, int reopen )
        }
 
        sc = slap_sasl_err2ldap( sc );
+
+#elif defined(SLAP_BUILTIN_SASL)
+       /* built-in SASL implementation */
+       SASL_CTX *ctx = (SASL_CTX *) SLAP_MALLOC(sizeof(SASL_CTX));
+       if( ctx == NULL ) return -1;
+
+       ctx->sc_external_ssf = 0;
+       BER_BVZERO( &ctx->sc_external_id );
+
+       conn->c_sasl_authctx = ctx;
 #endif
+
        return sc;
 }
 
 int slap_sasl_external(
        Connection *conn,
        slap_ssf_t ssf,
-       const char *auth_id )
+       struct berval *auth_id )
 {
 #if SASL_VERSION_MAJOR >= 2
        int sc;
@@ -1348,7 +1292,8 @@ int slap_sasl_external(
                return LDAP_OTHER;
        }
 
-       sc = sasl_setprop( ctx, SASL_AUTH_EXTERNAL, auth_id );
+       sc = sasl_setprop( ctx, SASL_AUTH_EXTERNAL,
+               auth_id ? auth_id->bv_val : NULL );
 
        if ( sc != SASL_OK ) {
                return LDAP_OTHER;
@@ -1365,7 +1310,7 @@ int slap_sasl_external(
 
        memset( &extprops, '\0', sizeof(extprops) );
        extprops.ssf = ssf;
-       extprops.auth_id = (char *) auth_id;
+       extprops.auth_id = auth_id ? auth_id->bv_val : NULL;
 
        sc = sasl_setprop( ctx, SASL_SSF_EXTERNAL,
                (void *) &extprops );
@@ -1373,6 +1318,18 @@ int slap_sasl_external(
        if ( sc != SASL_OK ) {
                return LDAP_OTHER;
        }
+#elif defined(SLAP_BUILTIN_SASL)
+       /* built-in SASL implementation */
+       SASL_CTX *ctx = conn->c_sasl_authctx;
+       if ( ctx == NULL ) return LDAP_UNAVAILABLE;
+
+       ctx->sc_external_ssf = ssf;
+       if( auth_id ) {
+               ctx->sc_external_id = *auth_id;
+               BER_BVZERO( auth_id );
+       } else {
+               BER_BVZERO( &ctx->sc_external_id );
+       }
 #endif
 
        return LDAP_SUCCESS;
@@ -1418,6 +1375,13 @@ char ** slap_sasl_mechs( Connection *conn )
                ch_free( mechstr );
 #endif
        }
+#elif defined(SLAP_BUILTIN_SASL)
+       /* builtin SASL implementation */
+       SASL_CTX *ctx = conn->c_sasl_authctx;
+       if ( ctx != NULL && ctx->sc_external_id.bv_val ) {
+               /* should check ssf */
+               mechs = ldap_str2charray( "EXTERNAL", "," );
+       }
 #endif
 
        return mechs;
@@ -1431,7 +1395,9 @@ int slap_sasl_close( Connection *conn )
        if( ctx != NULL ) {
                sasl_dispose( &ctx );
        }
-       if ( conn->c_sasl_sockctx && conn->c_sasl_authctx != conn->c_sasl_sockctx ) {
+       if ( conn->c_sasl_sockctx &&
+               conn->c_sasl_authctx != conn->c_sasl_sockctx )
+       {
                ctx = conn->c_sasl_sockctx;
                sasl_dispose( &ctx );
        }
@@ -1442,6 +1408,17 @@ int slap_sasl_close( Connection *conn )
 
        free( conn->c_sasl_extra );
        conn->c_sasl_extra = NULL;
+
+#elif defined(SLAP_BUILTIN_SASL)
+       SASL_CTX *ctx = conn->c_sasl_authctx;
+       if( ctx ) {
+               if( ctx->sc_external_id.bv_val ) {
+                       free( ctx->sc_external_id.bv_val );
+                       BER_BVZERO( &ctx->sc_external_id );
+               }
+               free( ctx );
+               conn->c_sasl_authctx = NULL;
+       }
 #endif
 
        return LDAP_SUCCESS;
@@ -1471,7 +1448,6 @@ int slap_sasl_bind( Operation *op, SlapReply *rs )
                op->orb_cred.bv_len );
 #endif
 
-
        if( ctx == NULL ) {
                send_ldap_error( op, rs, LDAP_UNAVAILABLE,
                        "SASL unavailable on this session" );
@@ -1532,8 +1508,7 @@ int slap_sasl_bind( Operation *op, SlapReply *rs )
                sasl_ssf_t *ssf = NULL;
 
                op->orb_edn = op->o_conn->c_sasl_dn;
-               op->o_conn->c_sasl_dn.bv_val = NULL;
-               op->o_conn->c_sasl_dn.bv_len = 0;
+               BER_BVZERO( &op->o_conn->c_sasl_dn );
                op->o_conn->c_sasl_done = 1;
 
                rs->sr_err = LDAP_SUCCESS;
@@ -1600,9 +1575,35 @@ int slap_sasl_bind( Operation *op, SlapReply *rs )
        Debug(LDAP_DEBUG_TRACE, "<== slap_sasl_bind: rc=%d\n", rs->sr_err, 0, 0);
 #endif
 
+#elif defined(SLAP_BUILTIN_SASL)
+       /* built-in SASL implementation */
+       SASL_CTX *ctx = op->o_conn->c_sasl_authctx;
+
+       if ( ctx == NULL ) {
+               send_ldap_error( op, rs, LDAP_OTHER,
+                       "Internal SASL Error" );
+
+       } else if ( bvmatch( &ext_bv, &op->o_conn->c_sasl_bind_mech ) ) {
+               /* EXTERNAL */
 
+               if( op->orb_cred.bv_len ) {
+                       rs->sr_text = "proxy authorization not support";
+                       rs->sr_err = LDAP_UNWILLING_TO_PERFORM;
+                       send_ldap_result( op, rs );
+
+               } else {
+                       op->orb_edn = ctx->sc_external_id;
+                       rs->sr_err = LDAP_SUCCESS;
+                       rs->sr_sasldata = NULL;
+                       send_ldap_sasl( op, rs );
+               }
+
+       } else {
+               send_ldap_error( op, rs, LDAP_AUTH_METHOD_NOT_SUPPORTED,
+                       "requested SASL mechanism not supported" );
+       }
 #else
-       send_ldap_error( op, rs, LDAP_UNAVAILABLE,
+       send_ldap_error( op, rs, LDAP_AUTH_METHOD_NOT_SUPPORTED,
                "SASL not supported" );
 #endif
 
@@ -1624,9 +1625,9 @@ char* slap_sasl_secprops( const char *in )
 int
 slap_sasl_setpass( Operation *op, SlapReply *rs )
 {
-       struct berval id = { 0, NULL }; /* needs to come from connection */
-       struct berval new = { 0, NULL };
-       struct berval old = { 0, NULL };
+       struct berval id = BER_BVNULL;  /* needs to come from connection */
+       struct berval new = BER_BVNULL;
+       struct berval old = BER_BVNULL;
 
        assert( ber_bvcmp( &slap_EXOP_MODIFY_PASSWD, &op->ore_reqoid ) == 0 );
 
@@ -1709,45 +1710,48 @@ done:
 #define        SET_DN          1
 #define        SET_U           2
 
-static struct berval ext_bv = BER_BVC( "EXTERNAL" );
-
-int slap_sasl_getdn( Connection *conn, Operation *op, char *id, int len,
+int slap_sasl_getdn( Connection *conn, Operation *op, struct berval *id,
        char *user_realm, struct berval *dn, int flags )
 {
        int rc, is_dn = SET_NONE, do_norm = 1;
        struct berval dn2, *mech;
 
        assert( conn );
+       assert( id );
 
 #ifdef NEW_LOGGING
        LDAP_LOG( TRANSPORT, ENTRY, 
                "slap_sasl_getdn: conn %d id=%s [len=%d]\n",
-               conn->c_connid, id ? (*id ? id : "<empty>") : "NULL", len );
+               conn->c_connid,
+               BER_BVISNULL( id ) ? "NULL" : ( BER_BVISEMPTY( id ) ? "<empty>" : id->bv_val ),
+               BER_BVISNULL( id ) ? 0 : ( BER_BVISEMPTY( id ) ? 0 : id->bv_len ) );
 #else
-       Debug( LDAP_DEBUG_ARGS, "slap_sasl_getdn: id=%s [len=%d]\n", 
-               id ? ( *id ? id : "<empty>" ) : "NULL", len, 0 );
+       Debug( LDAP_DEBUG_ARGS, "slap_sasl_getdn: conn %d id=%s [len=%d]\n", 
+               conn->c_connid,
+               BER_BVISNULL( id ) ? "NULL" : ( BER_BVISEMPTY( id ) ? "<empty>" : id->bv_val ),
+               BER_BVISNULL( id ) ? 0 : ( BER_BVISEMPTY( id ) ? 0 : id->bv_len ) );
 #endif
 
        if ( !op ) {
                op = conn->c_sasl_bindop;
        }
 
-       dn->bv_val = NULL;
-       dn->bv_len = 0;
-
-       if ( id ) {
-               if ( len == 0 ) len = strlen( id );
+       BER_BVZERO( dn );
 
+       if ( !BER_BVISNULL( id ) ) {
                /* Blatantly anonymous ID */
-               if ( len == sizeof("anonymous") - 1 &&
-                       !strcasecmp( id, "anonymous" ) ) {
+               static struct berval bv_anonymous = BER_BVC( "anonymous" );
+
+               if ( ber_bvstrcasecmp( id, &bv_anonymous ) == 0 ) {
                        return( LDAP_SUCCESS );
                }
+
        } else {
-               len = 0;
+               /* FIXME: if empty, should we stop? */
+               BER_BVSTR( id, "" );
        }
 
-       if ( conn->c_sasl_bind_mech.bv_len ) {
+       if ( !BER_BVISEMPTY( &conn->c_sasl_bind_mech ) ) {
                mech = &conn->c_sasl_bind_mech;
        } else {
                mech = &conn->c_authmech;
@@ -1759,82 +1763,59 @@ int slap_sasl_getdn( Connection *conn, Operation *op, char *id, int len,
         * is already normalized, so copy it and skip normalization.
         */
        if( flags & SLAP_GETDN_AUTHCID ) {
-               if( mech->bv_len == ext_bv.bv_len &&
-                       strcasecmp( ext_bv.bv_val, mech->bv_val ) == 0 )
-               {
+               if( bvmatch( mech, &ext_bv )) {
                        /* EXTERNAL DNs are already normalized */
+                       assert( !BER_BVISNULL( id ) );
+
                        do_norm = 0;
                        is_dn = SET_DN;
-                       ber_str2bv_x( id, len, 1, dn, op->o_tmpmemctx );
+                       ber_dupbv_x( dn, id, op->o_tmpmemctx );
 
                } else {
                        /* convert to u:<username> form */
                        is_dn = SET_U;
-                       dn->bv_val = id;
-                       dn->bv_len = len;
+                       *dn = *id;
                }
        }
+
        if( is_dn == SET_NONE ) {
-               if( !strncasecmp( id, "u:", sizeof("u:")-1 )) {
+               if( !strncasecmp( id->bv_val, "u:", STRLENOF( "u:" ) ) ) {
                        is_dn = SET_U;
-                       dn->bv_val = id+2;
-                       dn->bv_len = len-2;
-               } else if ( !strncasecmp( id, "dn:", sizeof("dn:")-1) ) {
+                       dn->bv_val = id->bv_val + STRLENOF( "u:" );
+                       dn->bv_len = id->bv_len - STRLENOF( "u:" );
+
+               } else if ( !strncasecmp( id->bv_val, "dn:", STRLENOF( "dn:" ) ) ) {
                        is_dn = SET_DN;
-                       dn->bv_val = id+3;
-                       dn->bv_len = len-3;
+                       dn->bv_val = id->bv_val + STRLENOF( "dn:" );
+                       dn->bv_len = id->bv_len - STRLENOF( "dn:" );
                }
        }
 
        /* No other possibilities from here */
        if( is_dn == SET_NONE ) {
-               dn->bv_val = NULL;
-               dn->bv_len = 0;
+               BER_BVZERO( dn );
                return( LDAP_INAPPROPRIATE_AUTH );
        }
 
        /* Username strings */
        if( is_dn == SET_U ) {
                char            *p;
-               struct berval   realm = { 0, NULL }, c1 = *dn;
+               struct berval   realm = BER_BVNULL, c1 = *dn;
+               ber_len_t       len;
 
-               len = dn->bv_len + sizeof("uid=")-1 + sizeof(",cn=auth")-1;
+               len = dn->bv_len + STRLENOF( "uid=" ) + STRLENOF( ",cn=auth" );
 
-#if 0
-               /* username may have embedded realm name */
-               /* FIXME:
-                * userids can legally have embedded '@' chars;
-                * the relm should be set by those mechanisms
-                * that support it by means of the user_realm
-                * variable
-                */
-               if( ( realm.bv_val = strrchr( dn->bv_val, '@') ) ) {
-                       char *r = realm.bv_val;
-
-                       realm.bv_val++;
-                       realm.bv_len = dn->bv_len - ( realm.bv_val - dn->bv_val );
-                       len += sizeof( ",cn=" ) - 2;
-                       c1.bv_len -= realm.bv_len + 1;
-
-                       if ( strchr( dn->bv_val, '@') == r ) {
-                               /* FIXME: ambiguity, is it the realm 
-                                * or something else? */
-                       }       
-                       
-               } else
-#endif
                if( user_realm && *user_realm ) {
-                       realm.bv_val = user_realm;
-                       realm.bv_len = strlen( user_realm );
-                       len += realm.bv_len + sizeof(",cn=") - 1;
+                       ber_str2bv( user_realm, 0, 0, &realm );
+                       len += realm.bv_len + STRLENOF( ",cn=" );
                }
 
                if( mech->bv_len ) {
-                       len += mech->bv_len + sizeof(",cn=")-1;
+                       len += mech->bv_len + STRLENOF( ",cn=" );
                }
 
                /* Build the new dn */
-               dn->bv_val = sl_malloc( len+1, op->o_tmpmemctx );
+               dn->bv_val = sl_malloc( len + 1, op->o_tmpmemctx );
                if( dn->bv_val == NULL ) {
 #ifdef NEW_LOGGING
                        LDAP_LOG( TRANSPORT, ERR, 
@@ -1883,16 +1864,15 @@ int slap_sasl_getdn( Connection *conn, Operation *op, char *id, int len,
                sl_free( dn->bv_val, op->o_tmpmemctx );
 
                if ( rc != LDAP_SUCCESS ) {
-                       dn->bv_val = NULL;
-                       dn->bv_len = 0;
+                       BER_BVZERO( dn );
                        return rc;
                }
                *dn = dn2;
        }
 
        /* Run thru regexp */
-       slap_sasl2dn( op, dn, &dn2 );
-       if( dn2.bv_val ) {
+       slap_sasl2dn( op, dn, &dn2, flags );
+       if( !BER_BVISNULL( &dn2 ) ) {
                sl_free( dn->bv_val, op->o_tmpmemctx );
                *dn = dn2;
 #ifdef NEW_LOGGING