version 1.24, 2000/02/29 22:48:01
|
version 1.26, 2000/04/11 23:39:52
|
Line 1
|
Line 1
|
/* filter.c - routines for parsing and dealing with filters */ |
/* filter.c - routines for parsing and dealing with filters */ |
/* $OpenLDAP: pkg/ldap/servers/slapd/filter.c,v 1.23 2000/02/14 19:57:40 kurt Exp $ */ |
/* $OpenLDAP: pkg/ldap/servers/slapd/filter.c,v 1.25 2000/03/01 21:59:34 kurt Exp $ */ |
/* |
/* |
* Copyright 1998-1999 The OpenLDAP Foundation, All Rights Reserved. |
* Copyright 1998-1999 The OpenLDAP Foundation, All Rights Reserved. |
* COPYING RESTRICTIONS APPLY, see COPYRIGHT file |
* COPYING RESTRICTIONS APPLY, see COPYRIGHT file |
Line 14
|
Line 14
|
|
|
#include "slap.h" |
#include "slap.h" |
|
|
static int get_filter_list(Connection *conn, BerElement *ber, Filter **f, char **fstr); |
static int get_filter_list( |
static int get_substring_filter(Connection *conn, BerElement *ber, Filter *f, char **fstr); |
Connection *conn, |
|
BerElement *ber, |
|
Filter **f, |
|
char **fstr, |
|
char **text ); |
|
static int get_substring_filter( |
|
Connection *conn, |
|
BerElement *ber, |
|
Filter *f, |
|
char **fstr, |
|
char **text ); |
|
|
int |
int |
get_filter( Connection *conn, BerElement *ber, Filter **filt, char **fstr ) |
get_filter( |
|
Connection *conn, |
|
BerElement *ber, |
|
Filter **filt, |
|
char **fstr, |
|
char **text ) |
{ |
{ |
ber_tag_t tag; |
ber_tag_t tag; |
ber_len_t len; |
ber_len_t len; |
Line 64 get_filter( Connection *conn, BerElement
|
Line 79 get_filter( Connection *conn, BerElement
|
tag = ber_peek_tag( ber, &len ); |
tag = ber_peek_tag( ber, &len ); |
|
|
if( tag == LBER_ERROR ) { |
if( tag == LBER_ERROR ) { |
|
*text = "error decoding filter"; |
return SLAPD_DISCONNECT; |
return SLAPD_DISCONNECT; |
} |
} |
|
|
Line 80 get_filter( Connection *conn, BerElement
|
Line 96 get_filter( Connection *conn, BerElement
|
#else |
#else |
case LDAP_FILTER_EQUALITY: |
case LDAP_FILTER_EQUALITY: |
Debug( LDAP_DEBUG_FILTER, "EQUALITY\n", 0, 0, 0 ); |
Debug( LDAP_DEBUG_FILTER, "EQUALITY\n", 0, 0, 0 ); |
if ( (err = get_ava( ber, &f->f_ava )) == LDAP_SUCCESS ) { |
if ( (err = get_ava( ber, &f->f_ava )) != LDAP_SUCCESS ) { |
*fstr = ch_malloc(4 + strlen( f->f_avtype ) + |
*text = "error decoding filter"; |
f->f_avvalue.bv_len); |
break; |
sprintf( *fstr, "(%s=%s)", f->f_avtype, |
|
f->f_avvalue.bv_val ); |
|
} |
} |
|
*fstr = ch_malloc(4 + strlen( f->f_avtype ) + |
|
f->f_avvalue.bv_len); |
|
sprintf( *fstr, "(%s=%s)", f->f_avtype, |
|
f->f_avvalue.bv_val ); |
break; |
break; |
|
|
case LDAP_FILTER_SUBSTRINGS: |
case LDAP_FILTER_SUBSTRINGS: |
Debug( LDAP_DEBUG_FILTER, "SUBSTRINGS\n", 0, 0, 0 ); |
Debug( LDAP_DEBUG_FILTER, "SUBSTRINGS\n", 0, 0, 0 ); |
err = get_substring_filter( conn, ber, f, fstr ); |
err = get_substring_filter( conn, ber, f, fstr, text ); |
break; |
break; |
|
|
case LDAP_FILTER_GE: |
case LDAP_FILTER_GE: |
Debug( LDAP_DEBUG_FILTER, "GE\n", 0, 0, 0 ); |
Debug( LDAP_DEBUG_FILTER, "GE\n", 0, 0, 0 ); |
if ( (err = get_ava( ber, &f->f_ava )) == LDAP_SUCCESS ) { |
if ( (err = get_ava( ber, &f->f_ava )) != LDAP_SUCCESS ) { |
*fstr = ch_malloc(5 + strlen( f->f_avtype ) + |
*text = "decoding filter error"; |
f->f_avvalue.bv_len); |
break; |
sprintf( *fstr, "(%s>=%s)", f->f_avtype, |
|
f->f_avvalue.bv_val ); |
|
} |
} |
|
*fstr = ch_malloc(5 + strlen( f->f_avtype ) + |
|
f->f_avvalue.bv_len); |
|
sprintf( *fstr, "(%s>=%s)", f->f_avtype, |
|
f->f_avvalue.bv_val ); |
break; |
break; |
|
|
case LDAP_FILTER_LE: |
case LDAP_FILTER_LE: |
Debug( LDAP_DEBUG_FILTER, "LE\n", 0, 0, 0 ); |
Debug( LDAP_DEBUG_FILTER, "LE\n", 0, 0, 0 ); |
if ( (err = get_ava( ber, &f->f_ava )) == LDAP_SUCCESS ) { |
if ( (err = get_ava( ber, &f->f_ava )) != LDAP_SUCCESS ) { |
*fstr = ch_malloc(5 + strlen( f->f_avtype ) + |
*text = "error decoding filter"; |
f->f_avvalue.bv_len); |
break; |
sprintf( *fstr, "(%s<=%s)", f->f_avtype, |
|
f->f_avvalue.bv_val ); |
|
} |
} |
|
*fstr = ch_malloc(5 + strlen( f->f_avtype ) + |
|
f->f_avvalue.bv_len); |
|
sprintf( *fstr, "(%s<=%s)", f->f_avtype, |
|
f->f_avvalue.bv_val ); |
break; |
break; |
|
|
case LDAP_FILTER_PRESENT: |
case LDAP_FILTER_PRESENT: |
Debug( LDAP_DEBUG_FILTER, "PRESENT\n", 0, 0, 0 ); |
Debug( LDAP_DEBUG_FILTER, "PRESENT\n", 0, 0, 0 ); |
if ( ber_scanf( ber, "a", &f->f_type ) == LBER_ERROR ) { |
if ( ber_scanf( ber, "a", &f->f_type ) == LBER_ERROR ) { |
err = SLAPD_DISCONNECT; |
err = SLAPD_DISCONNECT; |
|
*text = "error decoding filter"; |
break; |
break; |
} |
} |
|
|
Line 128 get_filter( Connection *conn, BerElement
|
Line 151 get_filter( Connection *conn, BerElement
|
|
|
case LDAP_FILTER_APPROX: |
case LDAP_FILTER_APPROX: |
Debug( LDAP_DEBUG_FILTER, "APPROX\n", 0, 0, 0 ); |
Debug( LDAP_DEBUG_FILTER, "APPROX\n", 0, 0, 0 ); |
if ( (err = get_ava( ber, &f->f_ava )) == LDAP_SUCCESS ) { |
if ( (err = get_ava( ber, &f->f_ava )) != LDAP_SUCCESS ) { |
*fstr = ch_malloc(5 + strlen( f->f_avtype ) + |
*text = "error decoding filter"; |
f->f_avvalue.bv_len); |
break; |
sprintf( *fstr, "(%s~=%s)", f->f_avtype, |
|
f->f_avvalue.bv_val ); |
|
} |
} |
|
*fstr = ch_malloc(5 + strlen( f->f_avtype ) + |
|
f->f_avvalue.bv_len); |
|
sprintf( *fstr, "(%s~=%s)", f->f_avtype, |
|
f->f_avvalue.bv_val ); |
break; |
break; |
#endif |
#endif |
|
|
case LDAP_FILTER_AND: |
case LDAP_FILTER_AND: |
Debug( LDAP_DEBUG_FILTER, "AND\n", 0, 0, 0 ); |
Debug( LDAP_DEBUG_FILTER, "AND\n", 0, 0, 0 ); |
if ( (err = get_filter_list( conn, ber, &f->f_and, &ftmp )) |
err = get_filter_list( conn, ber, &f->f_and, &ftmp, text ); |
== LDAP_SUCCESS ) { |
if ( err != LDAP_SUCCESS ) { |
if (ftmp == NULL) ftmp = ch_strdup(""); |
break; |
*fstr = ch_malloc( 4 + strlen( ftmp ) ); |
|
sprintf( *fstr, "(&%s)", ftmp ); |
|
free( ftmp ); |
|
} |
} |
|
if (ftmp == NULL) ftmp = ch_strdup(""); |
|
*fstr = ch_malloc( 4 + strlen( ftmp ) ); |
|
sprintf( *fstr, "(&%s)", ftmp ); |
|
free( ftmp ); |
break; |
break; |
|
|
case LDAP_FILTER_OR: |
case LDAP_FILTER_OR: |
Debug( LDAP_DEBUG_FILTER, "OR\n", 0, 0, 0 ); |
Debug( LDAP_DEBUG_FILTER, "OR\n", 0, 0, 0 ); |
if ( (err = get_filter_list( conn, ber, &f->f_or, &ftmp )) |
err = get_filter_list( conn, ber, &f->f_and, &ftmp, text ); |
== LDAP_SUCCESS ) { |
if ( err != LDAP_SUCCESS ) { |
if (ftmp == NULL) ftmp = ch_strdup(""); |
break; |
*fstr = ch_malloc( 4 + strlen( ftmp ) ); |
|
sprintf( *fstr, "(|%s)", ftmp ); |
|
free( ftmp ); |
|
} |
} |
|
if (ftmp == NULL) ftmp = ch_strdup(""); |
|
*fstr = ch_malloc( 4 + strlen( ftmp ) ); |
|
sprintf( *fstr, "(|%s)", ftmp ); |
|
free( ftmp ); |
break; |
break; |
|
|
case LDAP_FILTER_NOT: |
case LDAP_FILTER_NOT: |
Debug( LDAP_DEBUG_FILTER, "NOT\n", 0, 0, 0 ); |
Debug( LDAP_DEBUG_FILTER, "NOT\n", 0, 0, 0 ); |
(void) ber_skip_tag( ber, &len ); |
(void) ber_skip_tag( ber, &len ); |
if ( (err = get_filter( conn, ber, &f->f_not, &ftmp )) == LDAP_SUCCESS ) { |
err = get_filter( conn, ber, &f->f_not, &ftmp, text ); |
if (ftmp == NULL) ftmp = ch_strdup(""); |
if ( err != LDAP_SUCCESS ) { |
*fstr = ch_malloc( 4 + strlen( ftmp ) ); |
break; |
sprintf( *fstr, "(!%s)", ftmp ); |
|
free( ftmp ); |
|
} |
} |
|
if (ftmp == NULL) ftmp = ch_strdup(""); |
|
*fstr = ch_malloc( 4 + strlen( ftmp ) ); |
|
sprintf( *fstr, "(!%s)", ftmp ); |
|
free( ftmp ); |
break; |
break; |
|
|
case LDAP_FILTER_EXT: |
case LDAP_FILTER_EXT: |
Line 175 get_filter( Connection *conn, BerElement
|
Line 204 get_filter( Connection *conn, BerElement
|
Debug( LDAP_DEBUG_ANY, "extensible match not yet implemented.\n", |
Debug( LDAP_DEBUG_ANY, "extensible match not yet implemented.\n", |
f->f_choice, 0, 0 ); |
f->f_choice, 0, 0 ); |
err = LDAP_PROTOCOL_ERROR; |
err = LDAP_PROTOCOL_ERROR; |
|
*text = "extensible match not yet implemented"; |
break; |
break; |
|
|
default: |
default: |
Debug( LDAP_DEBUG_ANY, "unknown filter type %lu\n", |
Debug( LDAP_DEBUG_ANY, "unknown filter type %lu\n", |
f->f_choice, 0, 0 ); |
f->f_choice, 0, 0 ); |
err = LDAP_PROTOCOL_ERROR; |
err = LDAP_PROTOCOL_ERROR; |
|
*text = "unknown filter type"; |
break; |
break; |
} |
} |
|
|
Line 198 get_filter( Connection *conn, BerElement
|
Line 229 get_filter( Connection *conn, BerElement
|
} |
} |
|
|
static int |
static int |
get_filter_list( Connection *conn, BerElement *ber, Filter **f, char **fstr ) |
get_filter_list( Connection *conn, BerElement *ber, Filter **f, char **fstr, char **text ) |
{ |
{ |
Filter **new; |
Filter **new; |
int err; |
int err; |
Line 213 get_filter_list( Connection *conn, BerEl
|
Line 244 get_filter_list( Connection *conn, BerEl
|
for ( tag = ber_first_element( ber, &len, &last ); tag != LBER_DEFAULT; |
for ( tag = ber_first_element( ber, &len, &last ); tag != LBER_DEFAULT; |
tag = ber_next_element( ber, &len, last ) ) |
tag = ber_next_element( ber, &len, last ) ) |
{ |
{ |
if ( (err = get_filter( conn, ber, new, &ftmp )) != LDAP_SUCCESS ) |
err = get_filter( conn, ber, new, &ftmp, text ); |
|
if ( err != LDAP_SUCCESS ) |
return( err ); |
return( err ); |
|
|
if ( *fstr == NULL ) { |
if ( *fstr == NULL ) { |
*fstr = ftmp; |
*fstr = ftmp; |
} else { |
} else { |
Line 238 get_substring_filter(
|
Line 271 get_substring_filter(
|
Connection *conn, |
Connection *conn, |
BerElement *ber, |
BerElement *ber, |
Filter *f, |
Filter *f, |
char **fstr |
char **fstr, |
|
char **text |
) |
) |
{ |
{ |
ber_tag_t tag; |
ber_tag_t tag; |
Line 248 get_substring_filter(
|
Line 282 get_substring_filter(
|
char *last; |
char *last; |
int syntax; |
int syntax; |
|
|
|
*text = "error decoding filter"; |
|
|
Debug( LDAP_DEBUG_FILTER, "begin get_substring_filter\n", 0, 0, 0 ); |
Debug( LDAP_DEBUG_FILTER, "begin get_substring_filter\n", 0, 0, 0 ); |
|
|
if ( ber_scanf( ber, "{a" /*}*/, &f->f_sub_type ) == LBER_ERROR ) { |
if ( ber_scanf( ber, "{a" /*}*/, &f->f_sub_type ) == LBER_ERROR ) { |
return SLAPD_DISCONNECT; |
return SLAPD_DISCONNECT; |
} |
} |
|
|
attr_normalize( f->f_sub_type ); |
|
|
|
#ifdef SLAPD_SCHEMA_NOT_COMPAT |
#ifdef SLAPD_SCHEMA_NOT_COMPAT |
/* not yet implemented */ |
/* not yet implemented */ |
#else |
#else |
|
attr_normalize( f->f_sub_type ); |
|
|
/* should get real syntax and see if we have a substring matching rule */ |
/* should get real syntax and see if we have a substring matching rule */ |
syntax = attr_syntax( f->f_sub_type ); |
syntax = attr_syntax( f->f_sub_type ); |
#endif |
#endif |
Line 346 get_substring_filter(
|
Line 382 get_substring_filter(
|
break; |
break; |
|
|
default: |
default: |
Debug( LDAP_DEBUG_FILTER, " unknown type\n", tag, 0, |
Debug( LDAP_DEBUG_FILTER, " unknown type=%ld\n", |
0 ); |
(long) tag, 0, 0 ); |
|
|
ber_bvfree( val ); |
ber_bvfree( val ); |
|
|
return_error: |
return_error: |
Debug( LDAP_DEBUG_FILTER, " error=%d\n", rc, 0, 0 ); |
Debug( LDAP_DEBUG_FILTER, " error=%ld\n", |
|
(long) rc, 0, 0 ); |
|
|
if( fstr ) { |
if( fstr ) { |
free( *fstr ); |
free( *fstr ); |