]> git.sur5r.net Git - openldap/blob - servers/slapd/controls.c
Change slap_sasl_authorized to take an Operation instead of a Connection,
[openldap] / servers / slapd / controls.c
1 /* $OpenLDAP$ */
2 /* 
3  * Copyright 1999-2003 The OpenLDAP Foundation.
4  * All rights reserved.
5  *
6  * Redistribution and use in source and binary forms are permitted only
7  * as authorized by the OpenLDAP Public License.  A copy of this
8  * license is available at http://www.OpenLDAP.org/license.html or
9  * in file LICENSE in the top-level directory of the distribution.
10  */
11 #include "portable.h"
12
13 #include <stdio.h>
14
15 #include <ac/string.h>
16 #include <ac/socket.h>
17
18 #include "slap.h"
19
20 #include "../../libraries/liblber/lber-int.h"
21
22 static SLAP_CTRL_PARSE_FN parseProxyAuthz;
23 static SLAP_CTRL_PARSE_FN parseManageDSAit;
24 static SLAP_CTRL_PARSE_FN parseNoOp;
25 static SLAP_CTRL_PARSE_FN parsePagedResults;
26 static SLAP_CTRL_PARSE_FN parseValuesReturnFilter;
27 static SLAP_CTRL_PARSE_FN parsePermissiveModify;
28 static SLAP_CTRL_PARSE_FN parseDomainScope;
29
30 #ifdef LDAP_CONTROL_SUBENTRIES
31 static SLAP_CTRL_PARSE_FN parseSubentries;
32 #endif
33 #ifdef LDAP_CLIENT_UPDATE
34 static SLAP_CTRL_PARSE_FN parseClientUpdate;
35 #endif
36 #ifdef LDAP_SYNC
37 static SLAP_CTRL_PARSE_FN parseLdupSync;
38 #endif
39
40 #undef sc_mask /* avoid conflict with Irix 6.5 <sys/signal.h> */
41
42 static char *proxy_authz_extops[] = {
43         LDAP_EXOP_MODIFY_PASSWD,
44         LDAP_EXOP_X_WHO_AM_I,
45         NULL
46 };
47
48 struct slap_control {
49         /*
50          * Control OID
51          */
52         char *sc_oid;
53
54         /*
55          * Operations supported by control
56          */
57         slap_mask_t sc_mask;
58
59         /*
60          * Extended operations supported by control
61          */
62         char **sc_extendedops;
63
64         /*
65          * Control parsing callback
66          */
67         SLAP_CTRL_PARSE_FN *sc_parse;
68
69         LDAP_SLIST_ENTRY(slap_control) sc_next;
70 };
71
72 static LDAP_SLIST_HEAD(ControlsList, slap_control) controls_list
73         = LDAP_SLIST_HEAD_INITIALIZER(&controls_list);
74
75 /*
76  * all known request control OIDs should be added to this list
77  */
78 char **slap_known_controls = NULL;
79
80 static struct slap_control control_defs[] = {
81         { LDAP_CONTROL_VALUESRETURNFILTER,
82                 SLAP_CTRL_SEARCH, NULL,
83                 parseValuesReturnFilter, LDAP_SLIST_ENTRY_INITIALIZER(next) },
84 #ifdef LDAP_CONTROL_PAGEDRESULTS
85         { LDAP_CONTROL_PAGEDRESULTS,
86                 SLAP_CTRL_SEARCH, NULL,
87                 parsePagedResults, LDAP_SLIST_ENTRY_INITIALIZER(next) },
88 #endif
89 #ifdef LDAP_CONTROL_X_DOMAIN_SCOPE
90         { LDAP_CONTROL_X_DOMAIN_SCOPE,
91                 SLAP_CTRL_FRONTEND|SLAP_CTRL_SEARCH, NULL,
92                 parseDomainScope, LDAP_SLIST_ENTRY_INITIALIZER(next) },
93 #endif
94 #ifdef LDAP_CONTROL_X_PERMISSIVE_MODIFY
95         { LDAP_CONTROL_X_PERMISSIVE_MODIFY,
96                 SLAP_CTRL_MODIFY, NULL,
97                 parsePermissiveModify, LDAP_SLIST_ENTRY_INITIALIZER(next) },
98 #endif
99 #ifdef LDAP_CONTROL_SUBENTRIES
100         { LDAP_CONTROL_SUBENTRIES,
101                 SLAP_CTRL_SEARCH, NULL,
102                 parseSubentries, LDAP_SLIST_ENTRY_INITIALIZER(next) },
103 #endif
104         { LDAP_CONTROL_NOOP,
105                 SLAP_CTRL_ACCESS, NULL,
106                 parseNoOp, LDAP_SLIST_ENTRY_INITIALIZER(next) },
107 #ifdef LDAP_CLIENT_UPDATE
108         { LDAP_CONTROL_CLIENT_UPDATE,
109                 SLAP_CTRL_SEARCH, NULL,
110                 parseClientUpdate, LDAP_SLIST_ENTRY_INITIALIZER(next) },
111 #endif
112 #ifdef LDAP_SYNC
113         { LDAP_CONTROL_SYNC,
114                 SLAP_CTRL_SEARCH, NULL,
115                 parseLdupSync, LDAP_SLIST_ENTRY_INITIALIZER(next) },
116 #endif
117         { LDAP_CONTROL_MANAGEDSAIT,
118                 SLAP_CTRL_ACCESS, NULL,
119                 parseManageDSAit, LDAP_SLIST_ENTRY_INITIALIZER(next) },
120         { LDAP_CONTROL_PROXY_AUTHZ,
121                 SLAP_CTRL_FRONTEND|SLAP_CTRL_ACCESS, proxy_authz_extops,
122                 parseProxyAuthz, LDAP_SLIST_ENTRY_INITIALIZER(next) },
123         { NULL, 0, NULL, 0, LDAP_SLIST_ENTRY_INITIALIZER(next) }
124 };
125
126 /*
127  * Register a supported control.
128  *
129  * This can be called by an OpenLDAP plugin or, indirectly, by a
130  * SLAPI plugin calling slapi_register_supported_control().
131  */
132 int
133 register_supported_control(const char *controloid,
134         slap_mask_t controlmask,
135         char **controlexops,
136         SLAP_CTRL_PARSE_FN *controlparsefn)
137 {
138         struct slap_control *sc;
139         int i;
140
141         if ( controloid == NULL ) {
142                 return LDAP_PARAM_ERROR;
143         }
144
145         sc = (struct slap_control *)SLAP_MALLOC( sizeof( *sc ) );
146         if ( sc == NULL ) {
147                 return LDAP_NO_MEMORY;
148         }
149         sc->sc_oid = ch_strdup( controloid );
150         sc->sc_mask = controlmask;
151         if ( controlexops != NULL ) {
152                 sc->sc_extendedops = ldap_charray_dup( controlexops );
153                 if ( sc->sc_extendedops == NULL ) {
154                         ch_free( sc );
155                         return LDAP_NO_MEMORY;
156                 }
157         } else {
158                 sc->sc_extendedops = NULL;
159         }
160         sc->sc_parse = controlparsefn;
161
162         /* Update slap_known_controls, too. */
163         if ( slap_known_controls == NULL ) {
164                 slap_known_controls = (char **)SLAP_MALLOC( 2 * sizeof(char *) );
165                 if ( slap_known_controls == NULL ) {
166                         if ( sc->sc_extendedops != NULL ) ldap_charray_free( sc->sc_extendedops );
167                         ch_free( sc );
168                         return LDAP_NO_MEMORY;
169                 }
170                 slap_known_controls[0] = ch_strdup( sc->sc_oid );
171                 slap_known_controls[1] = NULL;
172         } else {
173                 for ( i = 0; slap_known_controls[i] != NULL; i++ )
174                         ;
175                 slap_known_controls = (char **)SLAP_REALLOC( slap_known_controls, (i + 2) * sizeof(char *) );
176                 if ( slap_known_controls == NULL ) {
177                         if ( sc->sc_extendedops != NULL ) ldap_charray_free( sc->sc_extendedops );
178                         ch_free( sc );
179                         return LDAP_NO_MEMORY;
180                 }
181                 slap_known_controls[i++] = ch_strdup( sc->sc_oid );
182                 slap_known_controls[i] = NULL;
183         }
184
185         LDAP_SLIST_NEXT( sc, sc_next ) = NULL;
186         LDAP_SLIST_INSERT_HEAD( &controls_list, sc, sc_next );
187
188         return LDAP_SUCCESS;
189 }
190
191 /*
192  * One-time initialization of internal controls.
193  */
194 int
195 slap_controls_init( void )
196 {
197         int i, rc;
198         struct slap_control *sc;
199
200         rc = LDAP_SUCCESS;
201
202         for ( i = 0; control_defs[i].sc_oid != NULL; i++ ) {
203                 rc = register_supported_control( control_defs[i].sc_oid,
204                         control_defs[i].sc_mask, control_defs[i].sc_extendedops,
205                         control_defs[i].sc_parse );
206                 if ( rc != LDAP_SUCCESS )
207                         break;
208         }
209
210         return rc;
211 }
212
213 /*
214  * Free memory associated with list of supported controls.
215  */
216 void
217 controls_destroy( void )
218 {
219         struct slap_control *sc;
220
221         while ( !LDAP_SLIST_EMPTY(&controls_list) ) {
222                 sc = LDAP_SLIST_FIRST(&controls_list);
223                 LDAP_SLIST_REMOVE_HEAD(&controls_list, sc_next);
224
225                 ch_free( sc->sc_oid );
226                 if ( sc->sc_extendedops != NULL ) {
227                         ldap_charray_free( sc->sc_extendedops );
228                 }
229                 ch_free( sc );
230         }
231         ldap_charray_free( slap_known_controls );
232 }
233
234 /*
235  * Format the supportedControl attribute of the root DSE,
236  * detailing which controls are supported by the directory
237  * server.
238  */
239 int
240 controls_root_dse_info( Entry *e )
241 {
242         AttributeDescription *ad_supportedControl
243                 = slap_schema.si_ad_supportedControl;
244         struct berval vals[2];
245         struct slap_control *sc;
246
247         vals[1].bv_val = NULL;
248         vals[1].bv_len = 0;
249
250         LDAP_SLIST_FOREACH( sc, &controls_list, sc_next ) {
251                 vals[0].bv_val = sc->sc_oid;
252                 vals[0].bv_len = strlen( sc->sc_oid );
253                 if ( attr_merge( e, ad_supportedControl, vals, NULL ) )
254                         return -1;
255         }
256
257         return 0;
258 }
259
260 /*
261  * Return a list of OIDs and operation masks for supported
262  * controls. Used by SLAPI.
263  */
264 int
265 get_supported_controls(char ***ctrloidsp,
266         slap_mask_t **ctrlmasks)
267 {
268         int i, n;
269         char **oids;
270         slap_mask_t *masks;
271         int rc;
272         struct slap_control *sc;
273
274         n = 0;
275
276         LDAP_SLIST_FOREACH( sc, &controls_list, sc_next ) {
277                 n++;
278         }
279
280         if ( n == 0 ) {
281                 *ctrloidsp = NULL;
282                 *ctrlmasks = NULL;
283                 return LDAP_SUCCESS;
284         }
285
286         oids = (char **)SLAP_MALLOC( (n + 1) * sizeof(char *) );
287         if ( oids == NULL ) {
288                 return LDAP_NO_MEMORY;
289         }
290         masks = (slap_mask_t *)SLAP_MALLOC( (n + 1) * sizeof(slap_mask_t) );
291         if  ( masks == NULL ) {
292                 ch_free( oids );
293                 return LDAP_NO_MEMORY;
294         }
295
296         n = 0;
297
298         LDAP_SLIST_FOREACH( sc, &controls_list, sc_next ) {
299                 oids[n] = ch_strdup( sc->sc_oid );
300                 masks[n] = sc->sc_mask;
301                 n++;
302         }
303         oids[n] = NULL;
304         masks[n] = 0;
305
306         *ctrloidsp = oids;
307         *ctrlmasks = masks;
308
309         return LDAP_SUCCESS;
310 }
311
312 /*
313  * Find a control given its OID.
314  */
315 static struct slap_control *
316 find_ctrl( const char *oid )
317 {
318         struct slap_control *sc;
319
320         LDAP_SLIST_FOREACH( sc, &controls_list, sc_next ) {
321                 if ( strcmp( oid, sc->sc_oid ) == 0 ) {
322                         return sc;
323                 }
324         }
325
326         return NULL;
327 }
328
329 void slap_free_ctrls(
330         Operation *op,
331         LDAPControl **ctrls
332 )
333 {
334         int i;
335
336         for (i=0; ctrls[i]; i++) {
337                 op->o_tmpfree(ctrls[i], op->o_tmpmemctx );
338         }
339         op->o_tmpfree( ctrls, op->o_tmpmemctx );
340 }
341
342 int get_ctrls(
343         Operation *op,
344         SlapReply *rs,
345         int sendres )
346 {
347         int nctrls = 0;
348         ber_tag_t tag;
349         ber_len_t len;
350         char *opaque;
351         BerElement *ber = op->o_ber;
352         struct slap_control *sc;
353         struct berval bv;
354
355         len = ber_pvt_ber_remaining(ber);
356
357         if( len == 0) {
358                 /* no controls */
359                 rs->sr_err = LDAP_SUCCESS;
360                 return rs->sr_err;
361         }
362
363         if(( tag = ber_peek_tag( ber, &len )) != LDAP_TAG_CONTROLS ) {
364                 if( tag == LBER_ERROR ) {
365                         rs->sr_err = SLAPD_DISCONNECT;
366                         rs->sr_text = "unexpected data in PDU";
367                 }
368
369                 goto return_results;
370         }
371
372 #ifdef NEW_LOGGING
373         LDAP_LOG( OPERATION, ENTRY,
374                 "get_ctrls: conn %lu\n", op->o_connid, 0, 0 );
375 #else
376         Debug( LDAP_DEBUG_TRACE,
377                 "=> get_ctrls\n", 0, 0, 0 );
378 #endif
379
380         if( op->o_protocol < LDAP_VERSION3 ) {
381                 rs->sr_err = SLAPD_DISCONNECT;
382                 rs->sr_text = "controls require LDAPv3";
383                 goto return_results;
384         }
385
386         /* one for first control, one for termination */
387         op->o_ctrls = op->o_tmpalloc( 2 * sizeof(LDAPControl *), op->o_tmpmemctx );
388
389 #if 0
390         if( op->ctrls == NULL ) {
391                 rs->sr_err = LDAP_NO_MEMORY;
392                 rs->sr_text = "no memory";
393                 goto return_results;
394         }
395 #endif
396
397         op->o_ctrls[nctrls] = NULL;
398
399         /* step through each element */
400         for( tag = ber_first_element( ber, &len, &opaque );
401                 tag != LBER_ERROR;
402                 tag = ber_next_element( ber, &len, opaque ) )
403         {
404                 LDAPControl *c;
405                 LDAPControl **tctrls;
406
407                 c = op->o_tmpalloc( sizeof(LDAPControl), op->o_tmpmemctx );
408                 memset(c, 0, sizeof(LDAPControl));
409
410                 /* allocate pointer space for current controls (nctrls)
411                  * + this control + extra NULL
412                  */
413                 tctrls = op->o_tmprealloc( op->o_ctrls,
414                         (nctrls+2) * sizeof(LDAPControl *), op->o_tmpmemctx );
415
416 #if 0
417                 if( tctrls == NULL ) {
418                         ch_free( c );
419                         ldap_controls_free(op->o_ctrls);
420                         op->o_ctrls = NULL;
421
422                         rs->sr_err = LDAP_NO_MEMORY;
423                         rs->sr_text = "no memory";
424                         goto return_results;
425                 }
426 #endif
427                 op->o_ctrls = tctrls;
428
429                 op->o_ctrls[nctrls++] = c;
430                 op->o_ctrls[nctrls] = NULL;
431
432                 tag = ber_scanf( ber, "{m" /*}*/, &bv );
433                 c->ldctl_oid = bv.bv_val;
434
435                 if( tag == LBER_ERROR ) {
436 #ifdef NEW_LOGGING
437                         LDAP_LOG( OPERATION, INFO, "get_ctrls: conn %lu get OID failed.\n",
438                                 op->o_connid, 0, 0 );
439 #else
440                         Debug( LDAP_DEBUG_TRACE, "=> get_ctrls: get oid failed.\n",
441                                 0, 0, 0 );
442 #endif
443
444                         slap_free_ctrls( op, op->o_ctrls );
445                         op->o_ctrls = NULL;
446                         rs->sr_err = SLAPD_DISCONNECT;
447                         rs->sr_text = "decoding controls error";
448                         goto return_results;
449
450                 } else if( c->ldctl_oid == NULL ) {
451 #ifdef NEW_LOGGING
452                         LDAP_LOG( OPERATION, INFO,
453                                 "get_ctrls: conn %lu got emtpy OID.\n",
454                                 op->o_connid, 0, 0 );
455 #else
456                         Debug( LDAP_DEBUG_TRACE,
457                                 "get_ctrls: conn %lu got emtpy OID.\n",
458                                 op->o_connid, 0, 0 );
459 #endif
460
461                         slap_free_ctrls( op, op->o_ctrls );
462                         op->o_ctrls = NULL;
463                         rs->sr_err = LDAP_PROTOCOL_ERROR;
464                         rs->sr_text = "OID field is empty";
465                         goto return_results;
466                 }
467
468                 tag = ber_peek_tag( ber, &len );
469
470                 if( tag == LBER_BOOLEAN ) {
471                         ber_int_t crit;
472                         tag = ber_scanf( ber, "b", &crit );
473
474                         if( tag == LBER_ERROR ) {
475 #ifdef NEW_LOGGING
476                                 LDAP_LOG( OPERATION, INFO, 
477                                         "get_ctrls: conn %lu get crit failed.\n", 
478                                         op->o_connid, 0, 0 );
479 #else
480                                 Debug( LDAP_DEBUG_TRACE, "=> get_ctrls: get crit failed.\n",
481                                         0, 0, 0 );
482 #endif
483                                 slap_free_ctrls( op, op->o_ctrls );
484                                 op->o_ctrls = NULL;
485                                 rs->sr_err = SLAPD_DISCONNECT;
486                                 rs->sr_text = "decoding controls error";
487                                 goto return_results;
488                         }
489
490                         c->ldctl_iscritical = (crit != 0);
491                         tag = ber_peek_tag( ber, &len );
492                 }
493
494                 if( tag == LBER_OCTETSTRING ) {
495                         tag = ber_scanf( ber, "m", &c->ldctl_value );
496
497                         if( tag == LBER_ERROR ) {
498 #ifdef NEW_LOGGING
499                                 LDAP_LOG( OPERATION, INFO, "get_ctrls: conn %lu: "
500                                         "%s (%scritical): get value failed.\n",
501                                         op->o_connid, c->ldctl_oid,
502                                         c->ldctl_iscritical ? "" : "non" );
503 #else
504                                 Debug( LDAP_DEBUG_TRACE, "=> get_ctrls: conn %lu: "
505                                         "%s (%scritical): get value failed.\n",
506                                         op->o_connid, c->ldctl_oid,
507                                         c->ldctl_iscritical ? "" : "non" );
508 #endif
509                                 slap_free_ctrls( op, op->o_ctrls );
510                                 op->o_ctrls = NULL;
511                                 rs->sr_err = SLAPD_DISCONNECT;
512                                 rs->sr_text = "decoding controls error";
513                                 goto return_results;
514                         }
515                 }
516
517 #ifdef NEW_LOGGING
518                 LDAP_LOG( OPERATION, INFO, 
519                         "get_ctrls: conn %lu oid=\"%s\" (%scritical)\n",
520                         op->o_connid, c->ldctl_oid, c->ldctl_iscritical ? "" : "non" );
521 #else
522                 Debug( LDAP_DEBUG_TRACE,
523                         "=> get_ctrls: oid=\"%s\" (%scritical)\n",
524                         c->ldctl_oid, c->ldctl_iscritical ? "" : "non", 0 );
525 #endif
526
527                 sc = find_ctrl( c->ldctl_oid );
528                 if( sc != NULL ) {
529                         /* recognized control */
530                         slap_mask_t tagmask;
531                         switch( op->o_tag ) {
532                         case LDAP_REQ_ADD:
533                                 tagmask = SLAP_CTRL_ADD;
534                                 break;
535                         case LDAP_REQ_BIND:
536                                 tagmask = SLAP_CTRL_BIND;
537                                 break;
538                         case LDAP_REQ_COMPARE:
539                                 tagmask = SLAP_CTRL_COMPARE;
540                                 break;
541                         case LDAP_REQ_DELETE:
542                                 tagmask = SLAP_CTRL_DELETE;
543                                 break;
544                         case LDAP_REQ_MODIFY:
545                                 tagmask = SLAP_CTRL_MODIFY;
546                                 break;
547                         case LDAP_REQ_RENAME:
548                                 tagmask = SLAP_CTRL_RENAME;
549                                 break;
550                         case LDAP_REQ_SEARCH:
551                                 tagmask = SLAP_CTRL_SEARCH;
552                                 break;
553                         case LDAP_REQ_UNBIND:
554                                 tagmask = SLAP_CTRL_UNBIND;
555                                 break;
556                         case LDAP_REQ_ABANDON:
557                                 tagmask = SLAP_CTRL_ABANDON;
558                                 break;
559                         case LDAP_REQ_EXTENDED:
560                                 tagmask=~0L;
561                                 assert( op->ore_reqoid.bv_val != NULL );
562                                 if( sc->sc_extendedops != NULL ) {
563                                         int i;
564                                         for( i=0; sc->sc_extendedops[i] != NULL; i++ ) {
565                                                 if( strcmp( op->ore_reqoid.bv_val, sc->sc_extendedops[i] )
566                                                         == 0 )
567                                                 {
568                                                         tagmask=0L;
569                                                         break;
570                                                 }
571                                         }
572                                 }
573                                 break;
574                         default:
575                                 rs->sr_err = LDAP_OTHER;
576                                 rs->sr_text = "controls internal error";
577                                 goto return_results;
578                         }
579
580                         if (( sc->sc_mask & tagmask ) == tagmask ) {
581                                 /* available extension */
582
583                                 if( !sc->sc_parse ) {
584                                         rs->sr_err = LDAP_OTHER;
585                                         rs->sr_text = "not yet implemented";
586                                         goto return_results;
587                                 }
588
589                                 rs->sr_err = sc->sc_parse( op, rs, c );
590
591                                 if( rs->sr_err != LDAP_SUCCESS ) goto return_results;
592
593                                 if ( sc->sc_mask & SLAP_CTRL_FRONTEND ) {
594                                         /* kludge to disable backend_control() check */
595                                         c->ldctl_iscritical = 0;
596
597                                 } else if ( tagmask == SLAP_CTRL_SEARCH &&
598                                         sc->sc_mask & SLAP_CTRL_FRONTEND_SEARCH )
599                                 {
600                                         /* kludge to disable backend_control() check */
601                                         c->ldctl_iscritical = 0;
602                                 }
603
604                         } else if( c->ldctl_iscritical ) {
605                                 /* unavailable CRITICAL control */
606                                 rs->sr_err = LDAP_UNAVAILABLE_CRITICAL_EXTENSION;
607                                 rs->sr_text = "critical extension is unavailable";
608                                 goto return_results;
609                         }
610
611                 } else if( c->ldctl_iscritical ) {
612                         /* unrecognized CRITICAL control */
613                         rs->sr_err = LDAP_UNAVAILABLE_CRITICAL_EXTENSION;
614                         rs->sr_text = "critical extension is not recognized";
615                         goto return_results;
616                 }
617         }
618
619 return_results:
620 #ifdef NEW_LOGGING
621         LDAP_LOG( OPERATION, RESULTS, 
622                 "get_ctrls: n=%d rc=%d err=\"%s\"\n",
623                 nctrls, rs->sr_err, rs->sr_text ? rs->sr_text : "" );
624 #else
625         Debug( LDAP_DEBUG_TRACE,
626                 "<= get_ctrls: n=%d rc=%d err=\"%s\"\n",
627                 nctrls, rs->sr_err, rs->sr_text ? rs->sr_text : "");
628 #endif
629
630         if( sendres && rs->sr_err != LDAP_SUCCESS ) {
631                 if( rs->sr_err == SLAPD_DISCONNECT ) {
632                         rs->sr_err = LDAP_PROTOCOL_ERROR;
633                         send_ldap_disconnect( op, rs );
634                         rs->sr_err = SLAPD_DISCONNECT;
635                 } else {
636                         send_ldap_result( op, rs );
637                 }
638         }
639
640         return rs->sr_err;
641 }
642
643 static int parseManageDSAit (
644         Operation *op,
645         SlapReply *rs,
646         LDAPControl *ctrl )
647 {
648         if ( op->o_managedsait != SLAP_NO_CONTROL ) {
649                 rs->sr_text = "manageDSAit control specified multiple times";
650                 return LDAP_PROTOCOL_ERROR;
651         }
652
653         if ( ctrl->ldctl_value.bv_len ) {
654                 rs->sr_text = "manageDSAit control value not empty";
655                 return LDAP_PROTOCOL_ERROR;
656         }
657
658         op->o_managedsait = ctrl->ldctl_iscritical
659                 ? SLAP_CRITICAL_CONTROL
660                 : SLAP_NONCRITICAL_CONTROL;
661
662         return LDAP_SUCCESS;
663 }
664
665 static int parseProxyAuthz (
666         Operation *op,
667         SlapReply *rs,
668         LDAPControl *ctrl )
669 {
670         int rc;
671         struct berval dn = { 0, NULL };
672
673         if ( op->o_proxy_authz != SLAP_NO_CONTROL ) {
674                 rs->sr_text = "proxy authorization control specified multiple times";
675                 return LDAP_PROTOCOL_ERROR;
676         }
677
678         op->o_proxy_authz = ctrl->ldctl_iscritical
679                 ? SLAP_CRITICAL_CONTROL
680                 : SLAP_NONCRITICAL_CONTROL;
681
682 #ifdef NEW_LOGGING
683         LDAP_LOG( OPERATION, ARGS, 
684                 "parseProxyAuthz: conn %lu authzid=\"%s\"\n", 
685                 op->o_connid,
686                 ctrl->ldctl_value.bv_len ?  ctrl->ldctl_value.bv_val : "anonymous",
687                 0 );
688 #else
689         Debug( LDAP_DEBUG_ARGS,
690                 "parseProxyAuthz: conn %lu authzid=\"%s\"\n", 
691                 op->o_connid,
692                 ctrl->ldctl_value.bv_len ?  ctrl->ldctl_value.bv_val : "anonymous",
693                 0 );
694 #endif
695
696         if( ctrl->ldctl_value.bv_len == 0 ) {
697 #ifdef NEW_LOGGING
698                 LDAP_LOG( OPERATION, RESULTS, 
699                         "parseProxyAuthz: conn=%lu anonymous\n", 
700                         op->o_connid, 0, 0 );
701 #else
702                 Debug( LDAP_DEBUG_TRACE,
703                         "parseProxyAuthz: conn=%lu anonymous\n", 
704                         op->o_connid, 0, 0 );
705 #endif
706
707                 /* anonymous */
708                 free( op->o_dn.bv_val );
709                 op->o_dn.bv_len = 0;
710                 op->o_dn.bv_val = ch_strdup( "" );
711
712                 free( op->o_ndn.bv_val );
713                 op->o_ndn.bv_len = 0;
714                 op->o_ndn.bv_val = ch_strdup( "" );
715
716                 return LDAP_SUCCESS;
717         }
718
719         rc = slap_sasl_getdn( op->o_conn, op,
720                 ctrl->ldctl_value.bv_val, ctrl->ldctl_value.bv_len,
721                 NULL, &dn, SLAP_GETDN_AUTHZID );
722
723         if( rc != LDAP_SUCCESS || !dn.bv_len ) {
724                 if ( dn.bv_val ) {
725                         ch_free( dn.bv_val );
726                 }
727                 rs->sr_text = "authzId mapping failed";
728                 return LDAP_PROXY_AUTHZ_FAILURE;
729         }
730
731 #ifdef NEW_LOGGING
732         LDAP_LOG( OPERATION, RESULTS, 
733                 "parseProxyAuthz: conn=%lu \"%s\"\n", 
734                 op->o_connid,
735                 dn.bv_len ? dn.bv_val : "(NULL)", 0 );
736 #else
737         Debug( LDAP_DEBUG_TRACE,
738                 "parseProxyAuthz: conn=%lu \"%s\"\n", 
739                 op->o_connid,
740                 dn.bv_len ? dn.bv_val : "(NULL)", 0 );
741 #endif
742
743         rc = slap_sasl_authorized( op, &op->o_ndn, &dn );
744
745         if( rc ) {
746                 ch_free( dn.bv_val );
747                 rs->sr_text = "not authorized to assume identity";
748                 return LDAP_PROXY_AUTHZ_FAILURE;
749         }
750
751         ch_free( op->o_dn.bv_val );
752         ch_free( op->o_ndn.bv_val );
753
754         op->o_dn.bv_val = NULL;
755         op->o_ndn = dn;
756
757         /*
758          * NOTE: since slap_sasl_getdn() returns a normalized dn,
759          * from now on op->o_dn is normalized
760          */
761         ber_dupbv( &op->o_dn, &dn );
762
763         return LDAP_SUCCESS;
764 }
765
766 static int parseNoOp (
767         Operation *op,
768         SlapReply *rs,
769         LDAPControl *ctrl )
770 {
771         if ( op->o_noop != SLAP_NO_CONTROL ) {
772                 rs->sr_text = "noop control specified multiple times";
773                 return LDAP_PROTOCOL_ERROR;
774         }
775
776         if ( ctrl->ldctl_value.bv_len ) {
777                 rs->sr_text = "noop control value not empty";
778                 return LDAP_PROTOCOL_ERROR;
779         }
780
781         op->o_noop = ctrl->ldctl_iscritical
782                 ? SLAP_CRITICAL_CONTROL
783                 : SLAP_NONCRITICAL_CONTROL;
784
785         return LDAP_SUCCESS;
786 }
787
788 #ifdef LDAP_CONTROL_PAGEDRESULTS
789 static int parsePagedResults (
790         Operation *op,
791         SlapReply *rs,
792         LDAPControl *ctrl )
793 {
794         ber_tag_t tag;
795         ber_int_t size;
796         BerElement *ber;
797         struct berval cookie = { 0, NULL };
798
799         if ( op->o_pagedresults != SLAP_NO_CONTROL ) {
800                 rs->sr_text = "paged results control specified multiple times";
801                 return LDAP_PROTOCOL_ERROR;
802         }
803
804         if ( ctrl->ldctl_value.bv_len == 0 ) {
805                 rs->sr_text = "paged results control value is empty (or absent)";
806                 return LDAP_PROTOCOL_ERROR;
807         }
808
809         /* Parse the control value
810          *      realSearchControlValue ::= SEQUENCE {
811          *              size    INTEGER (0..maxInt),
812          *                              -- requested page size from client
813          *                              -- result set size estimate from server
814          *              cookie  OCTET STRING
815          * }
816          */
817         ber = ber_init( &ctrl->ldctl_value );
818         if( ber == NULL ) {
819                 rs->sr_text = "internal error";
820                 return LDAP_OTHER;
821         }
822
823         tag = ber_scanf( ber, "{im}", &size, &cookie );
824         (void) ber_free( ber, 1 );
825
826         if( tag == LBER_ERROR ) {
827                 rs->sr_text = "paged results control could not be decoded";
828                 return LDAP_PROTOCOL_ERROR;
829         }
830
831         if( size < 0 ) {
832                 rs->sr_text = "paged results control size invalid";
833                 return LDAP_PROTOCOL_ERROR;
834         }
835
836         if( cookie.bv_len ) {
837                 PagedResultsCookie reqcookie;
838                 if( cookie.bv_len != sizeof( reqcookie ) ) {
839                         /* bad cookie */
840                         rs->sr_text = "paged results cookie is invalid";
841                         return LDAP_PROTOCOL_ERROR;
842                 }
843
844                 AC_MEMCPY( &reqcookie, cookie.bv_val, sizeof( reqcookie ));
845
846                 if( reqcookie > op->o_pagedresults_state.ps_cookie ) {
847                         /* bad cookie */
848                         rs->sr_text = "paged results cookie is invalid";
849                         return LDAP_PROTOCOL_ERROR;
850
851                 } else if( reqcookie < op->o_pagedresults_state.ps_cookie ) {
852                         rs->sr_text = "paged results cookie is invalid or old";
853                         return LDAP_UNWILLING_TO_PERFORM;
854                 }
855         } else {
856                 /* Initial request.  Initialize state. */
857                 op->o_pagedresults_state.ps_cookie = 0;
858                 op->o_pagedresults_state.ps_id = NOID;
859         }
860
861         op->o_pagedresults_size = size;
862
863         op->o_pagedresults = ctrl->ldctl_iscritical
864                 ? SLAP_CRITICAL_CONTROL
865                 : SLAP_NONCRITICAL_CONTROL;
866
867         return LDAP_SUCCESS;
868 }
869 #endif
870
871 int parseValuesReturnFilter (
872         Operation *op,
873         SlapReply *rs,
874         LDAPControl *ctrl )
875 {
876         BerElement      *ber;
877         struct berval   fstr = { 0, NULL };
878         const char *err_msg = "";
879
880         if ( op->o_valuesreturnfilter != SLAP_NO_CONTROL ) {
881                 rs->sr_text = "valuesReturnFilter control specified multiple times";
882                 return LDAP_PROTOCOL_ERROR;
883         }
884
885         if ( ctrl->ldctl_value.bv_len == 0 ) {
886                 rs->sr_text = "valuesReturnFilter control value is empty (or absent)";
887                 return LDAP_PROTOCOL_ERROR;
888         }
889
890         ber = ber_init( &(ctrl->ldctl_value) );
891         if (ber == NULL) {
892                 rs->sr_text = "internal error";
893                 return LDAP_OTHER;
894         }
895         
896         rs->sr_err = get_vrFilter( op, ber, &(op->vrFilter), &rs->sr_text);
897
898         if( rs->sr_err != LDAP_SUCCESS ) {
899                 if( rs->sr_err == SLAPD_DISCONNECT ) {
900                         rs->sr_err = LDAP_PROTOCOL_ERROR;
901                         send_ldap_disconnect( op, rs );
902                         rs->sr_err = SLAPD_DISCONNECT;
903                 } else {
904                         send_ldap_result( op, rs );
905                 }
906                 if( op->vrFilter != NULL) vrFilter_free( op, op->vrFilter ); 
907
908         }
909 #ifdef LDAP_DEBUG
910         else {
911                 vrFilter2bv( op, op->vrFilter, &fstr );
912         }
913
914 #ifdef NEW_LOGGING
915         LDAP_LOG( OPERATION, ARGS, 
916                 "parseValuesReturnFilter: conn %d       vrFilter: %s\n", 
917                 op->o_connid, fstr.bv_len ? fstr.bv_val : "empty" , 0 );
918 #else
919         Debug( LDAP_DEBUG_ARGS, "       vrFilter: %s\n",
920                 fstr.bv_len ? fstr.bv_val : "empty", 0, 0 );
921 #endif
922         op->o_tmpfree( fstr.bv_val, op->o_tmpmemctx );
923 #endif
924
925         op->o_valuesreturnfilter = ctrl->ldctl_iscritical
926                 ? SLAP_CRITICAL_CONTROL
927                 : SLAP_NONCRITICAL_CONTROL;
928
929         rs->sr_err = LDAP_SUCCESS;
930         return LDAP_SUCCESS;
931 }
932
933 #ifdef LDAP_CONTROL_SUBENTRIES
934 static int parseSubentries (
935         Operation *op,
936         SlapReply *rs,
937         LDAPControl *ctrl )
938 {
939         if ( op->o_subentries != SLAP_NO_CONTROL ) {
940                 rs->sr_text = "subentries control specified multiple times";
941                 return LDAP_PROTOCOL_ERROR;
942         }
943
944         /* FIXME: should use BER library */
945         if( ( ctrl->ldctl_value.bv_len != 3 )
946                 && ( ctrl->ldctl_value.bv_val[0] != 0x01 )
947                 && ( ctrl->ldctl_value.bv_val[1] != 0x01 ))
948         {
949                 rs->sr_text = "subentries control value encoding is bogus";
950                 return LDAP_PROTOCOL_ERROR;
951         }
952
953         op->o_subentries = ctrl->ldctl_iscritical
954                 ? SLAP_CRITICAL_CONTROL
955                 : SLAP_NONCRITICAL_CONTROL;
956
957         op->o_subentries_visibility = (ctrl->ldctl_value.bv_val[2] != 0x00);
958
959         return LDAP_SUCCESS;
960 }
961 #endif
962
963 #ifdef LDAP_CONTROL_X_PERMISSIVE_MODIFY
964 static int parsePermissiveModify (
965         Operation *op,
966         SlapReply *rs,
967         LDAPControl *ctrl )
968 {
969         if ( op->o_permissive_modify != SLAP_NO_CONTROL ) {
970                 rs->sr_text = "permissiveModify control specified multiple times";
971                 return LDAP_PROTOCOL_ERROR;
972         }
973
974         if ( ctrl->ldctl_value.bv_len ) {
975                 rs->sr_text = "permissiveModify control value not empty";
976                 return LDAP_PROTOCOL_ERROR;
977         }
978
979         op->o_permissive_modify = ctrl->ldctl_iscritical
980                 ? SLAP_CRITICAL_CONTROL
981                 : SLAP_NONCRITICAL_CONTROL;
982
983         return LDAP_SUCCESS;
984 }
985 #endif
986
987 #ifdef LDAP_CONTROL_X_DOMAIN_SCOPE
988 static int parseDomainScope (
989         Operation *op,
990         SlapReply *rs,
991         LDAPControl *ctrl )
992 {
993         if ( op->o_domain_scope != SLAP_NO_CONTROL ) {
994                 rs->sr_text = "domainScope control specified multiple times";
995                 return LDAP_PROTOCOL_ERROR;
996         }
997
998         if ( ctrl->ldctl_value.bv_len ) {
999                 rs->sr_text = "domainScope control value not empty";
1000                 return LDAP_PROTOCOL_ERROR;
1001         }
1002
1003         op->o_domain_scope = ctrl->ldctl_iscritical
1004                 ? SLAP_CRITICAL_CONTROL
1005                 : SLAP_NONCRITICAL_CONTROL;
1006
1007         return LDAP_SUCCESS;
1008 }
1009 #endif
1010
1011 #ifdef LDAP_CLIENT_UPDATE
1012 static int parseClientUpdate (
1013         Operation *op,
1014         SlapReply *rs,
1015         LDAPControl *ctrl )
1016 {
1017         ber_tag_t tag;
1018         BerElement *ber;
1019         ber_int_t type;
1020         ber_int_t interval;
1021         ber_len_t len;
1022         struct berval scheme = { 0, NULL };
1023         struct berval cookie = { 0, NULL };
1024
1025         if ( op->o_clientupdate != SLAP_NO_CONTROL ) {
1026                 rs->sr_text = "LCUP client update control specified multiple times";
1027                 return LDAP_PROTOCOL_ERROR;
1028         }
1029
1030 #ifdef LDAP_SYNC
1031         if ( op->o_sync != SLAP_NO_CONTROL ) {
1032                 rs->sr_text = "LDAP Client Update and Sync controls used together";
1033                 return LDAP_PROTOCOL_ERROR;
1034         }
1035 #endif
1036
1037         if ( ctrl->ldctl_value.bv_len == 0 ) {
1038                 rs->sr_text = "LCUP client update control value is empty (or absent)";
1039                 return LDAP_PROTOCOL_ERROR;
1040         }
1041
1042         /* Parse the control value
1043          *      ClientUpdateControlValue ::= SEQUENCE {
1044          *              updateType      ENUMERATED {
1045          *                                      synchronizeOnly {0},
1046          *                                      synchronizeAndPersist {1},
1047          *                                      persistOnly {2} },
1048          *              sendCookieInterval INTEGER OPTIONAL,
1049          *              cookie          LCUPCookie OPTIONAL
1050          *      }
1051          */
1052
1053         ber = ber_init( &ctrl->ldctl_value );
1054         if( ber == NULL ) {
1055                 rs->sr_text = "internal error";
1056                 return LDAP_OTHER;
1057         }
1058
1059         if ( (tag = ber_scanf( ber, "{i" /*}*/, &type )) == LBER_ERROR ) {
1060                 rs->sr_text = "LCUP client update control : decoding error";
1061                 return LDAP_PROTOCOL_ERROR;
1062         }
1063
1064         switch( type ) {
1065         case LDAP_CUP_SYNC_ONLY:
1066                 type = SLAP_LCUP_SYNC;
1067                 break;
1068         case LDAP_CUP_SYNC_AND_PERSIST:
1069                 type = SLAP_LCUP_SYNC_AND_PERSIST;
1070                 break;
1071         case LDAP_CUP_PERSIST_ONLY:
1072                 type = SLAP_LCUP_PERSIST;
1073                 break;
1074         default:
1075                 rs->sr_text = "LCUP client update control : unknown update type";
1076                 return LDAP_PROTOCOL_ERROR;
1077         }
1078
1079         if ( (tag = ber_peek_tag( ber, &len )) == LBER_DEFAULT ) {
1080                 rs->sr_text = "LCUP client update control : decoding error";
1081                 return LDAP_PROTOCOL_ERROR;
1082         }
1083
1084         if ( tag == LDAP_CUP_TAG_INTERVAL ) {
1085                 if ( (tag = ber_scanf( ber, "i", &interval )) == LBER_ERROR ) {
1086                         rs->sr_text = "LCUP client update control : decoding error";
1087                         return LDAP_PROTOCOL_ERROR;
1088                 }
1089                 
1090                 if ( interval <= 0 ) {
1091                         /* server chooses interval */
1092                         interval = LDAP_CUP_DEFAULT_SEND_COOKIE_INTERVAL;
1093                 }
1094
1095         } else {
1096                 /* server chooses interval */
1097                 interval = LDAP_CUP_DEFAULT_SEND_COOKIE_INTERVAL;
1098         }
1099
1100         if ( (tag = ber_peek_tag( ber, &len )) == LBER_DEFAULT ) {
1101                 rs->sr_text = "LCUP client update control : decoding error";
1102                 return LDAP_PROTOCOL_ERROR;
1103         }
1104
1105         if ( tag == LDAP_CUP_TAG_COOKIE ) {
1106                 if ( (tag = ber_scanf( ber, /*{*/ "{mm}}",
1107                         &scheme, &cookie )) == LBER_ERROR )
1108                 {
1109                         rs->sr_text = "LCUP client update control : decoding error";
1110                         return LDAP_PROTOCOL_ERROR;
1111                 }
1112         }
1113
1114         /* TODO : Cookie Scheme Validation */
1115 #if 0
1116         if ( lcup_cookie_scheme_validate(scheme) != LDAP_SUCCESS ) {
1117                 rs->sr_text = "Unsupported LCUP cookie scheme";
1118                 return LCUP_UNSUPPORTED_SCHEME;
1119         }
1120
1121         if ( lcup_cookie_validate(scheme, cookie) != LDAP_SUCCESS ) {
1122                 rs->sr_text = "Invalid LCUP cookie";
1123                 return LCUP_INVALID_COOKIE;
1124         }
1125 #endif
1126
1127         ber_dupbv( &op->o_clientupdate_state, &cookie );
1128
1129         (void) ber_free( ber, 1 );
1130
1131         op->o_clientupdate_type = (char) type;
1132         op->o_clientupdate_interval = interval;
1133
1134         op->o_clientupdate = ctrl->ldctl_iscritical
1135                 ? SLAP_CRITICAL_CONTROL
1136                 : SLAP_NONCRITICAL_CONTROL;
1137
1138         return LDAP_SUCCESS;
1139 }
1140 #endif
1141
1142 #ifdef LDAP_SYNC
1143 static int parseLdupSync (
1144         Operation *op,
1145         SlapReply *rs,
1146         LDAPControl *ctrl )
1147 {
1148         ber_tag_t tag;
1149         BerElement *ber;
1150         ber_int_t mode;
1151         ber_len_t len;
1152         struct berval cookie = { 0, NULL };
1153
1154         if ( op->o_sync != SLAP_NO_CONTROL ) {
1155                 rs->sr_text = "LDAP Sync control specified multiple times";
1156                 return LDAP_PROTOCOL_ERROR;
1157         }
1158
1159 #ifdef LDAP_CLIENT_UPDATE
1160         if ( op->o_clientupdate != SLAP_NO_CONTROL ) {
1161                 rs->sr_text = "LDAP Sync and LDAP Client Update controls used together";
1162                 return LDAP_PROTOCOL_ERROR;
1163         }
1164 #endif
1165
1166         if ( ctrl->ldctl_value.bv_len == 0 ) {
1167                 rs->sr_text = "LDAP Sync control value is empty (or absent)";
1168                 return LDAP_PROTOCOL_ERROR;
1169         }
1170
1171         /* Parse the control value
1172          *      syncRequestValue ::= SEQUENCE {
1173          *              mode   ENUMERATED {
1174          *                      -- 0 unused
1175          *                      refreshOnly             (1),
1176          *                      -- 2 reserved
1177          *                      refreshAndPersist       (3)
1178          *              },
1179          *              cookie  syncCookie OPTIONAL
1180          *      }
1181          */
1182
1183         ber = ber_init( &ctrl->ldctl_value );
1184         if( ber == NULL ) {
1185                 rs->sr_text = "internal error";
1186                 return LDAP_OTHER;
1187         }
1188
1189         if ( (tag = ber_scanf( ber, "{i" /*}*/, &mode )) == LBER_ERROR ) {
1190                 rs->sr_text = "LDAP Sync control : mode decoding error";
1191                 return LDAP_PROTOCOL_ERROR;
1192         }
1193
1194         switch( mode ) {
1195         case LDAP_SYNC_REFRESH_ONLY:
1196                 mode = SLAP_SYNC_REFRESH;
1197                 break;
1198         case LDAP_SYNC_REFRESH_AND_PERSIST:
1199                 mode = SLAP_SYNC_REFRESH_AND_PERSIST;
1200                 break;
1201         default:
1202                 rs->sr_text = "LDAP Sync control : unknown update mode";
1203                 return LDAP_PROTOCOL_ERROR;
1204         }
1205
1206         tag = ber_peek_tag( ber, &len );
1207
1208         if ( tag == LDAP_SYNC_TAG_COOKIE ) {
1209                 if (( ber_scanf( ber, /*{*/ "m}",
1210                                         &cookie )) == LBER_ERROR ) {
1211                         rs->sr_text = "LDAP Sync control : cookie decoding error";
1212                         return LDAP_PROTOCOL_ERROR;
1213                 }
1214         } else {
1215                 if (( ber_scanf( ber, /*{*/ "}")) == LBER_ERROR ) {
1216                         rs->sr_text = "LDAP Sync control : decoding error";
1217                         return LDAP_PROTOCOL_ERROR;
1218                 }
1219                 cookie.bv_len = 0;
1220                 cookie.bv_val = NULL;
1221         }
1222
1223         /* TODO : Cookie Scheme Validation */
1224 #if 0
1225         if ( lcup_cookie_scheme_validate(scheme) != LDAP_SUCCESS ) {
1226                 rs->sr_text = "Unsupported LCUP cookie scheme";
1227                 return LCUP_UNSUPPORTED_SCHEME;
1228         }
1229
1230         if ( lcup_cookie_validate(scheme, cookie) != LDAP_SUCCESS ) {
1231                 rs->sr_text = "Invalid LCUP cookie";
1232                 return LCUP_INVALID_COOKIE;
1233         }
1234 #endif
1235
1236         ber_dupbv( &op->o_sync_state, &cookie );
1237
1238         (void) ber_free( ber, 1 );
1239
1240         op->o_sync_mode = (char) mode;
1241
1242         op->o_sync = ctrl->ldctl_iscritical
1243                 ? SLAP_CRITICAL_CONTROL
1244                 : SLAP_NONCRITICAL_CONTROL;
1245
1246         return LDAP_SUCCESS;
1247 }
1248 #endif