]> git.sur5r.net Git - openldap/blobdiff - servers/slapd/filter.c
Install *.schema only
[openldap] / servers / slapd / filter.c
index 1278915e020c7f786525ce63f6de30303ff5b995..e9cfa1fe3b9d0077917dbb28325c10ab40c68426 100644 (file)
@@ -19,13 +19,14 @@ static int  get_filter_list(
        BerElement *ber,
        Filter **f,
        char **fstr,
-       char **text );
+       const char **text );
+
 static int     get_substring_filter(
        Connection *conn,
        BerElement *ber,
        Filter *f,
        char **fstr,
-       char **text );
+       const char **text );
 
 int
 get_filter(
@@ -33,13 +34,13 @@ get_filter(
        BerElement *ber,
        Filter **filt,
        char **fstr,
-       char **text )
+       const char **text )
 {
        ber_tag_t       tag;
        ber_len_t       len;
        int             err;
        Filter          *f;
-       char            *ftmp;
+       char            *ftmp = NULL;
 
        Debug( LDAP_DEBUG_FILTER, "begin get_filter\n", 0, 0, 0 );
 
@@ -94,12 +95,18 @@ get_filter(
        case LDAP_FILTER_EQUALITY:
                Debug( LDAP_DEBUG_FILTER, "EQUALITY\n", 0, 0, 0 );
 
-               if ( (err = get_ava( ber, &f->f_ava )) != LDAP_SUCCESS ) {
-                       *text = "error decoding filter";
+#ifdef SLAPD_SCHEMA_NOT_COMPAT
+               err = get_ava( ber, &f->f_ava, SLAP_MR_EQUALITY, text );
+#else
+               err = get_ava( ber, &f->f_ava, text );
+#endif
+               if ( err != LDAP_SUCCESS ) {
                        break;
                }
 
 #ifdef SLAPD_SCHEMA_NOT_COMPAT
+               assert( f->f_ava != NULL );
+
                *fstr = ch_malloc( sizeof("(=)")
                        + f->f_av_desc->ad_cname->bv_len
                        + f->f_av_value->bv_len );
@@ -125,8 +132,12 @@ get_filter(
        case LDAP_FILTER_GE:
                Debug( LDAP_DEBUG_FILTER, "GE\n", 0, 0, 0 );
 
-               if ( (err = get_ava( ber, &f->f_ava )) != LDAP_SUCCESS ) {
-                       *text = "decoding filter error";
+#ifdef SLAPD_SCHEMA_NOT_COMPAT
+               err = get_ava( ber, &f->f_ava, SLAP_MR_ORDERING, text );
+#else
+               err = get_ava( ber, &f->f_ava, text );
+#endif
+               if ( err != LDAP_SUCCESS ) {
                        break;
                }
 
@@ -151,13 +162,17 @@ get_filter(
        case LDAP_FILTER_LE:
                Debug( LDAP_DEBUG_FILTER, "LE\n", 0, 0, 0 );
 
-               if ( (err = get_ava( ber, &f->f_ava )) != LDAP_SUCCESS ) {
-                       *text = "decoding filter error";
+#ifdef SLAPD_SCHEMA_NOT_COMPAT
+               err = get_ava( ber, &f->f_ava, SLAP_MR_ORDERING, text );
+#else
+               err = get_ava( ber, &f->f_ava, text );
+#endif
+               if ( err != LDAP_SUCCESS ) {
                        break;
                }
 
-#ifdef SLAPD_SCHEMA_NOT_COMPAT
 
+#ifdef SLAPD_SCHEMA_NOT_COMPAT
                *fstr = ch_malloc( sizeof("(<=)")
                        + f->f_av_desc->ad_cname->bv_len
                        + f->f_av_value->bv_len );
@@ -187,24 +202,21 @@ get_filter(
                }
 
 #ifdef SLAPD_SCHEMA_NOT_COMPAT
-               {
-                       char *text;
-                       int rc;
-
-                       err = slap_bv2ad( &type, &f->f_desc, &text );
-
-                       if( err != LDAP_SUCCESS ) {
-                               ch_free( type.bv_val );
-                               break;
-                       }
+               f->f_desc = NULL;
+               err = slap_bv2ad( &type, &f->f_desc, text );
 
+               if( err != LDAP_SUCCESS ) {
                        ch_free( type.bv_val );
+                       break;
                }
 
+               ch_free( type.bv_val );
+
                *fstr = ch_malloc( sizeof("(=*)")
                        + f->f_desc->ad_cname->bv_len );
                sprintf( *fstr, "(%s=*)",
                        f->f_desc->ad_cname->bv_val );
+
 #else
                f->f_type = type.bv_val;
                err = LDAP_SUCCESS;
@@ -218,8 +230,12 @@ get_filter(
        case LDAP_FILTER_APPROX:
                Debug( LDAP_DEBUG_FILTER, "APPROX\n", 0, 0, 0 );
 
-               if ( (err = get_ava( ber, &f->f_ava )) != LDAP_SUCCESS ) {
-                       *text = "decoding filter error";
+#ifdef SLAPD_SCHEMA_NOT_COMPAT
+               err = get_ava( ber, &f->f_ava, SLAP_MR_EQUALITY_APPROX, text );
+#else
+               err = get_ava( ber, &f->f_ava, text );
+#endif
+               if ( err != LDAP_SUCCESS ) {
                        break;
                }
 
@@ -247,10 +263,10 @@ get_filter(
                if ( err != LDAP_SUCCESS ) {
                        break;
                }
-               if (ftmp == NULL) ftmp = ch_strdup("");
-               *fstr = ch_malloc( 4 + strlen( ftmp ) );
-               sprintf( *fstr, "(&%s)", ftmp );
-               free( ftmp );
+               *fstr = ch_malloc( sizeof("(&)")
+                       + ( ftmp == NULL ? 0 : strlen( ftmp ) ) );
+               sprintf( *fstr, "(&%s)",
+                       ftmp == NULL ? "" : ftmp );
                break;
 
        case LDAP_FILTER_OR:
@@ -259,10 +275,10 @@ get_filter(
                if ( err != LDAP_SUCCESS ) {
                        break;
                }
-               if (ftmp == NULL) ftmp = ch_strdup("");
-               *fstr = ch_malloc( 4 + strlen( ftmp ) );
-               sprintf( *fstr, "(|%s)", ftmp );
-               free( ftmp );
+               *fstr = ch_malloc( sizeof("(!)")
+                       + ( ftmp == NULL ? 0 : strlen( ftmp ) ) );
+               sprintf( *fstr, "(|%s)",
+                       ftmp == NULL ? "" : ftmp );
                break;
 
        case LDAP_FILTER_NOT:
@@ -272,33 +288,48 @@ get_filter(
                if ( err != LDAP_SUCCESS ) {
                        break;
                }
-               if (ftmp == NULL) ftmp = ch_strdup("");
-               *fstr = ch_malloc( 4 + strlen( ftmp ) );
-               sprintf( *fstr, "(!%s)", ftmp );
-               free( ftmp );
+               *fstr = ch_malloc( sizeof("(!)")
+                       + ( ftmp == NULL ? 0 : strlen( ftmp ) ) );
+               sprintf( *fstr, "(!%s)",
+                       ftmp == NULL ? "" : ftmp );
                break;
 
        case LDAP_FILTER_EXT:
                /* not yet implemented */
                Debug( LDAP_DEBUG_ANY, "extensible match not yet implemented.\n",
                       f->f_choice, 0, 0 );
-               err = LDAP_PROTOCOL_ERROR;
-               *text = "extensible match not yet implemented";
+               f->f_choice = SLAPD_FILTER_COMPUTED;
+               f->f_result = SLAPD_COMPARE_UNDEFINED;
+               *fstr = ch_strdup( "(extended)" );
                break;
 
        default:
                Debug( LDAP_DEBUG_ANY, "get_filter: unknown filter type=%lu\n",
                       f->f_choice, 0, 0 );
-               err = LDAP_PROTOCOL_ERROR;
-               *text = "unknown filter type";
+               f->f_choice = SLAPD_FILTER_COMPUTED;
+               f->f_result = SLAPD_COMPARE_UNDEFINED;
+               *fstr = ch_strdup( "(undefined)" );
                break;
        }
 
+       free( ftmp );
+
        if ( err != LDAP_SUCCESS ) {
-               free( (char *) f );
                if ( *fstr != NULL ) {
                        free( *fstr );
                }
+
+               if( err != SLAPD_DISCONNECT ) {
+                       /* ignore error */
+                       f->f_choice = SLAPD_FILTER_COMPUTED;
+                       f->f_result = SLAPD_COMPARE_UNDEFINED;
+                       *fstr = ch_strdup( "(badfilter)" );
+                       err = LDAP_SUCCESS;
+                       *filt = f;
+
+               } else {
+                       free(f);
+               }
        } else {
                *filt = f;
        }
@@ -308,7 +339,9 @@ get_filter(
 }
 
 static int
-get_filter_list( Connection *conn, BerElement *ber, Filter **f, char **fstr, char **text )
+get_filter_list( Connection *conn, BerElement *ber,
+       Filter **f, char **fstr,
+       const char **text )
 {
        Filter          **new;
        int             err;
@@ -349,29 +382,45 @@ get_substring_filter(
     BerElement *ber,
     Filter     *f,
     char       **fstr,
-       char    **text
+       const char      **text
 )
 {
        ber_tag_t       tag;
        ber_len_t       len;
        ber_tag_t       rc;
-       struct berval *val;
+       struct berval *value;
        char            *last;
-       char            *type;
+       struct berval type;
+#ifdef SLAPD_SCHEMA_NOT_COMPAT
+       struct berval *nvalue;
+#else
        int             syntax;
-
+#endif
        *text = "error decoding filter";
 
        Debug( LDAP_DEBUG_FILTER, "begin get_substring_filter\n", 0, 0, 0 );
 
-       if ( ber_scanf( ber, "{a" /*}*/, &type ) == LBER_ERROR ) {
+       if ( ber_scanf( ber, "{o" /*}*/, &type ) == LBER_ERROR ) {
                return SLAPD_DISCONNECT;
        }
 
 #ifdef SLAPD_SCHEMA_NOT_COMPAT
-       /* not yet implemented */
+       f->f_sub = ch_calloc( 1, sizeof(SubstringsAssertion) );
+       f->f_sub_desc = NULL;
+       rc = slap_bv2ad( &type, &f->f_sub_desc, text );
+
+       ch_free( type.bv_val );
+
+       if( rc != LDAP_SUCCESS ) {
+               text = NULL;
+               ch_free( f->f_sub );
+               f->f_choice = SLAPD_FILTER_COMPUTED;
+               f->f_result = SLAPD_COMPARE_UNDEFINED;
+               *fstr = ch_strdup( "(undefined)" );
+               return LDAP_SUCCESS;
+       }
 #else
-       f->f_sub_type = type;
+       f->f_sub_type = type.bv_val;
        attr_normalize( f->f_sub_type );
 
        /* should get real syntax and see if we have a substring matching rule */
@@ -383,7 +432,11 @@ get_substring_filter(
        f->f_sub_final = NULL;
 
 #ifdef SLAPD_SCHEMA_NOT_COMPAT
-       /* not yet implemented */
+       if( fstr ) {
+               *fstr = ch_malloc( sizeof("(=" /*)*/) +
+                       f->f_sub_desc->ad_cname->bv_len );
+               sprintf( *fstr, "(%s=" /*)*/, f->f_sub_desc->ad_cname->bv_val );
+       }
 #else
        if( fstr ) {
                *fstr = ch_malloc( strlen( f->f_sub_type ) + 3 );
@@ -394,73 +447,110 @@ get_substring_filter(
        for ( tag = ber_first_element( ber, &len, &last ); tag != LBER_DEFAULT;
            tag = ber_next_element( ber, &len, last ) )
        {
-               rc = ber_scanf( ber, "O", &val );
+#ifdef SLAPD_SCHEMA_NOT_COMPAT
+               unsigned usage;
+#endif
+
+               rc = ber_scanf( ber, "O", &value );
                if ( rc == LBER_ERROR ) {
                        rc = SLAPD_DISCONNECT;
                        goto return_error;
                }
 
-               if ( val == NULL || val->bv_len == 0 ) {
-                       ber_bvfree( val );
+               if ( value == NULL || value->bv_len == 0 ) {
+                       ber_bvfree( value );
                        rc = LDAP_INVALID_SYNTAX;
                        goto return_error;
                } 
 
-               rc = LDAP_PROTOCOL_ERROR;
-
 #ifdef SLAPD_SCHEMA_NOT_COMPAT
-               /* not yet implemented */
+               switch ( tag ) {
+               case LDAP_SUBSTRING_INITIAL:
+                       usage = SLAP_MR_SUBSTR_INITIAL;
+                       break;
+
+               case LDAP_SUBSTRING_ANY:
+                       usage = SLAP_MR_SUBSTR_ANY;
+                       break;
+
+               case LDAP_SUBSTRING_FINAL:
+                       usage = SLAP_MR_SUBSTR_FINAL;
+                       break;
+
+               default:
+                       rc = LDAP_PROTOCOL_ERROR;
+
+                       Debug( LDAP_DEBUG_FILTER,
+                               "  unknown substring choice=%ld\n",
+                               (long) tag, 0, 0 );
+
+                       ber_bvfree( value );
+                       goto return_error;
+               }
+
+               rc = value_normalize( f->f_sub_desc, usage, value, &nvalue, text );
+               ber_bvfree( value );
+
+               if( rc != LDAP_SUCCESS ) {
+                       goto return_error;
+               }
+
+               value = nvalue;
 #else
+
                /* we should call a substring syntax normalization routine */
-               value_normalize( val->bv_val, syntax );
+               value_normalize( value->bv_val, syntax );
                /* this is bogus, value_normalize should take a berval */
-               val->bv_len = strlen( val->bv_val );
+               value->bv_len = strlen( value->bv_val );
 #endif
 
+               rc = LDAP_PROTOCOL_ERROR;
+
                switch ( tag ) {
                case LDAP_SUBSTRING_INITIAL:
                        Debug( LDAP_DEBUG_FILTER, "  INITIAL\n", 0, 0, 0 );
                        if ( f->f_sub_initial != NULL ) {
-                               ber_bvfree( val );
+                               ber_bvfree( value );
                                goto return_error;
                        }
-                       f->f_sub_initial = val;
+
+                       f->f_sub_initial = value;
 
                        if( fstr ) {
                                *fstr = ch_realloc( *fstr,
-                                       strlen( *fstr ) + val->bv_len + 1 );
-                               strcat( *fstr, val->bv_val );
+                                       strlen( *fstr ) + value->bv_len + 1 );
+                               strcat( *fstr, value->bv_val );
                        }
                        break;
 
                case LDAP_SUBSTRING_ANY:
                        Debug( LDAP_DEBUG_FILTER, "  ANY\n", 0, 0, 0 );
-                       if( ber_bvecadd( &f->f_sub_any, val ) < 0 ) {
-                               ber_bvfree( val );
+                       if( ber_bvecadd( &f->f_sub_any, value ) < 0 ) {
+                               ber_bvfree( value );
                                goto return_error;
                        }
 
                        if( fstr ) {
                                *fstr = ch_realloc( *fstr,
-                                       strlen( *fstr ) + val->bv_len + 2 );
+                                       strlen( *fstr ) + value->bv_len + 2 );
                                strcat( *fstr, "*" );
-                               strcat( *fstr, val->bv_val );
+                               strcat( *fstr, value->bv_val );
                        }
                        break;
 
                case LDAP_SUBSTRING_FINAL:
                        Debug( LDAP_DEBUG_FILTER, "  FINAL\n", 0, 0, 0 );
                        if ( f->f_sub_final != NULL ) {
-                               ber_bvfree( val );
+                               ber_bvfree( value );
                                goto return_error;
                        }
-                       f->f_sub_final = val;
+                       f->f_sub_final = value;
 
                        if( fstr ) {
                                *fstr = ch_realloc( *fstr,
-                                       strlen( *fstr ) + val->bv_len + 2 );
+                                       strlen( *fstr ) + value->bv_len + 2 );
                                strcat( *fstr, "*" );
-                               strcat( *fstr, val->bv_val );
+                               strcat( *fstr, value->bv_val );
                        }
                        break;
 
@@ -469,7 +559,7 @@ get_substring_filter(
                                "  unknown substring type=%ld\n",
                                (long) tag, 0, 0 );
 
-                       ber_bvfree( val );
+                       ber_bvfree( value );
 
 return_error:
                        Debug( LDAP_DEBUG_FILTER, "  error=%ld\n",
@@ -481,13 +571,16 @@ return_error:
                        }
 
 #ifdef SLAPD_SCHEMA_NOT_COMPAT
-                       /* not yet implemented */
+                       ad_free( f->f_sub_desc, 1 );
 #else
                        ch_free( f->f_sub_type );
 #endif
                        ber_bvfree( f->f_sub_initial );
                        ber_bvecfree( f->f_sub_any );
                        ber_bvfree( f->f_sub_final );
+#ifdef SLAPD_SCHEMA_NOT_COMPAT
+                       ch_free( f->f_sub );
+#endif
                        return rc;
                }
        }
@@ -599,7 +692,8 @@ filter_print( Filter *f )
                        f->f_av_desc->ad_cname->bv_val,
                    f->f_av_value->bv_val );
 #else
-               fprintf( stderr, "(%s=%s)", f->f_ava.ava_type,
+               fprintf( stderr, "(%s=%s)",
+                       f->f_ava.ava_type,
                    f->f_ava.ava_value.bv_val );
 #endif
                break;
@@ -610,7 +704,8 @@ filter_print( Filter *f )
                        f->f_av_desc->ad_cname->bv_val,
                    f->f_av_value->bv_val );
 #else
-               fprintf( stderr, "(%s>=%s)", f->f_ava.ava_type,
+               fprintf( stderr, "(%s>=%s)",
+                       f->f_ava.ava_type,
                    f->f_ava.ava_value.bv_val );
 #endif
                break;
@@ -621,7 +716,8 @@ filter_print( Filter *f )
                        f->f_ava->aa_desc->ad_cname->bv_val,
                    f->f_ava->aa_value->bv_val );
 #else
-               fprintf( stderr, "(%s<=%s)", f->f_ava.ava_type,
+               fprintf( stderr, "(%s<=%s)",
+                       f->f_ava.ava_type,
                    f->f_ava.ava_value.bv_val );
 #endif
                break;
@@ -632,7 +728,8 @@ filter_print( Filter *f )
                        f->f_ava->aa_desc->ad_cname->bv_val,
                    f->f_ava->aa_value->bv_val );
 #else
-               fprintf( stderr, "(%s~=%s)", f->f_ava.ava_type,
+               fprintf( stderr, "(%s~=%s)",
+                       f->f_ava.ava_type,
                    f->f_ava.ava_value.bv_val );
 #endif
                break;
@@ -642,18 +739,22 @@ filter_print( Filter *f )
                fprintf( stderr, "(%s=" /*)*/,
                        f->f_sub_desc->ad_cname->bv_val );
 #else
-               fprintf( stderr, "(%s=" /*)*/, f->f_sub_type );
+               fprintf( stderr, "(%s=" /*)*/,
+                       f->f_sub_type );
 #endif
                if ( f->f_sub_initial != NULL ) {
-                       fprintf( stderr, "%s", f->f_sub_initial->bv_val );
+                       fprintf( stderr, "%s",
+                               f->f_sub_initial->bv_val );
                }
                if ( f->f_sub_any != NULL ) {
                        for ( i = 0; f->f_sub_any[i] != NULL; i++ ) {
-                               fprintf( stderr, "*%s", f->f_sub_any[i]->bv_val );
+                               fprintf( stderr, "*%s",
+                                       f->f_sub_any[i]->bv_val );
                        }
                }
                if ( f->f_sub_final != NULL ) {
-                       fprintf( stderr, "*%s", f->f_sub_final->bv_val );
+                       fprintf( stderr,
+                               "*%s", f->f_sub_final->bv_val );
                }
                fprintf( stderr, /*(*/ ")" );
                break;
@@ -663,7 +764,8 @@ filter_print( Filter *f )
                fprintf( stderr, "(%s=*)",
                        f->f_desc->ad_cname->bv_val );
 #else
-               fprintf( stderr, "(%s=*)", f->f_type );
+               fprintf( stderr, "(%s=*)",
+                       f->f_type );
 #endif
                break;
 
@@ -680,7 +782,7 @@ filter_print( Filter *f )
                break;
 
        case SLAPD_FILTER_COMPUTED:
-               fprintf( stderr, "(%s)",
+               fprintf( stderr, "(?=%s)",
                        f->f_result == LDAP_COMPARE_FALSE ? "false" :
                        f->f_result == LDAP_COMPARE_TRUE ? "true" :
                        f->f_result == SLAPD_COMPARE_UNDEFINED ? "undefined" :
@@ -688,7 +790,7 @@ filter_print( Filter *f )
                break;
 
        default:
-               fprintf( stderr, "(unknown filter %lu)", f->f_choice );
+               fprintf( stderr, "(unknown-filter=%lu)", f->f_choice );
                break;
        }
 }