Merge pull request #12 from nicowilliams/krb5_admin_patches_2nd
[metze/heimdal/wip.git] / kadmin / server.c
1 /*
2  * Copyright (c) 1997 - 2005 Kungliga Tekniska Högskolan
3  * (Royal Institute of Technology, Stockholm, Sweden).
4  * All rights reserved.
5  *
6  * Redistribution and use in source and binary forms, with or without
7  * modification, are permitted provided that the following conditions
8  * are met:
9  *
10  * 1. Redistributions of source code must retain the above copyright
11  *    notice, this list of conditions and the following disclaimer.
12  *
13  * 2. Redistributions in binary form must reproduce the above copyright
14  *    notice, this list of conditions and the following disclaimer in the
15  *    documentation and/or other materials provided with the distribution.
16  *
17  * 3. Neither the name of the Institute nor the names of its contributors
18  *    may be used to endorse or promote products derived from this software
19  *    without specific prior written permission.
20  *
21  * THIS SOFTWARE IS PROVIDED BY THE INSTITUTE AND CONTRIBUTORS ``AS IS'' AND
22  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
23  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
24  * ARE DISCLAIMED.  IN NO EVENT SHALL THE INSTITUTE OR CONTRIBUTORS BE LIABLE
25  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
26  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
27  * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
28  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
29  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
30  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
31  * SUCH DAMAGE.
32  */
33
34 #include "kadmin_locl.h"
35 #include <krb5-private.h>
36
37 static kadm5_ret_t
38 kadmind_dispatch(void *kadm_handlep, krb5_boolean initial,
39                  krb5_data *in, krb5_data *out)
40 {
41     kadm5_ret_t ret;
42     int32_t cmd, mask, tmp;
43     kadm5_server_context *contextp = kadm_handlep;
44     char client[128], name[128], name2[128];
45     const char *op = "";
46     krb5_principal princ, princ2;
47     kadm5_principal_ent_rec ent;
48     char *password, *expression;
49     krb5_keyblock *new_keys;
50     krb5_key_salt_tuple *ks_tuple = NULL;
51     krb5_boolean keepold = FALSE;
52     int n_ks_tuple = 0;
53     int n_keys;
54     char **princs;
55     int n_princs;
56     int keys_ok = 0;
57     krb5_storage *sp;
58
59     krb5_unparse_name_fixed(contextp->context, contextp->caller,
60                             client, sizeof(client));
61
62     sp = krb5_storage_from_data(in);
63     if (sp == NULL)
64         krb5_errx(contextp->context, 1, "out of memory");
65
66     krb5_ret_int32(sp, &cmd);
67     switch(cmd){
68     case kadm_get:{
69         op = "GET";
70         ret = krb5_ret_principal(sp, &princ);
71         if(ret)
72             goto fail;
73         ret = krb5_ret_int32(sp, &mask);
74         if(ret){
75             krb5_free_principal(contextp->context, princ);
76             goto fail;
77         }
78         mask |= KADM5_PRINCIPAL;
79         krb5_unparse_name_fixed(contextp->context, princ, name, sizeof(name));
80         krb5_warnx(contextp->context, "%s: %s %s", client, op, name);
81         ret = _kadm5_acl_check_permission(contextp, KADM5_PRIV_GET_KEYS, princ);
82         if (ret == 0)
83             keys_ok = 1;
84         else
85             ret = _kadm5_acl_check_permission(contextp, KADM5_PRIV_GET, princ);
86         if(ret){
87             krb5_free_principal(contextp->context, princ);
88             goto fail;
89         }
90         ret = kadm5_get_principal(kadm_handlep, princ, &ent, mask);
91         krb5_storage_free(sp);
92         sp = krb5_storage_emem();
93         krb5_store_int32(sp, ret);
94         if(ret == 0){
95             if (keys_ok)
96                 kadm5_store_principal_ent(sp, &ent);
97             else
98                 kadm5_store_principal_ent_nokeys(sp, &ent);
99             kadm5_free_principal_ent(kadm_handlep, &ent);
100         }
101         krb5_free_principal(contextp->context, princ);
102         break;
103     }
104     case kadm_delete:{
105         op = "DELETE";
106         ret = krb5_ret_principal(sp, &princ);
107         if(ret)
108             goto fail;
109         krb5_unparse_name_fixed(contextp->context, princ, name, sizeof(name));
110         krb5_warnx(contextp->context, "%s: %s %s", client, op, name);
111         ret = _kadm5_acl_check_permission(contextp, KADM5_PRIV_DELETE, princ);
112         if(ret){
113             krb5_free_principal(contextp->context, princ);
114             goto fail;
115         }
116         ret = kadm5_delete_principal(kadm_handlep, princ);
117         krb5_free_principal(contextp->context, princ);
118         krb5_storage_free(sp);
119         sp = krb5_storage_emem();
120         krb5_store_int32(sp, ret);
121         break;
122     }
123     case kadm_create:{
124         op = "CREATE";
125         ret = kadm5_ret_principal_ent(sp, &ent);
126         if(ret)
127             goto fail;
128         ret = krb5_ret_int32(sp, &mask);
129         if(ret){
130             kadm5_free_principal_ent(contextp->context, &ent);
131             goto fail;
132         }
133         ret = krb5_ret_string(sp, &password);
134         if(ret){
135             kadm5_free_principal_ent(contextp->context, &ent);
136             goto fail;
137         }
138         krb5_unparse_name_fixed(contextp->context, ent.principal,
139                                 name, sizeof(name));
140         krb5_warnx(contextp->context, "%s: %s %s", client, op, name);
141         ret = _kadm5_acl_check_permission(contextp, KADM5_PRIV_ADD,
142                                           ent.principal);
143         if(ret){
144             kadm5_free_principal_ent(contextp->context, &ent);
145             memset(password, 0, strlen(password));
146             free(password);
147             goto fail;
148         }
149         ret = kadm5_create_principal(kadm_handlep, &ent,
150                                      mask, password);
151         kadm5_free_principal_ent(kadm_handlep, &ent);
152         memset(password, 0, strlen(password));
153         free(password);
154         krb5_storage_free(sp);
155         sp = krb5_storage_emem();
156         krb5_store_int32(sp, ret);
157         break;
158     }
159     case kadm_modify:{
160         op = "MODIFY";
161         ret = kadm5_ret_principal_ent(sp, &ent);
162         if(ret)
163             goto fail;
164         ret = krb5_ret_int32(sp, &mask);
165         if(ret){
166             kadm5_free_principal_ent(contextp, &ent);
167             goto fail;
168         }
169         krb5_unparse_name_fixed(contextp->context, ent.principal,
170                                 name, sizeof(name));
171         krb5_warnx(contextp->context, "%s: %s %s", client, op, name);
172         ret = _kadm5_acl_check_permission(contextp, KADM5_PRIV_MODIFY,
173                                           ent.principal);
174         if(ret){
175             kadm5_free_principal_ent(contextp, &ent);
176             goto fail;
177         }
178         ret = kadm5_modify_principal(kadm_handlep, &ent, mask);
179         kadm5_free_principal_ent(kadm_handlep, &ent);
180         krb5_storage_free(sp);
181         sp = krb5_storage_emem();
182         krb5_store_int32(sp, ret);
183         break;
184     }
185     case kadm_rename:{
186         op = "RENAME";
187         ret = krb5_ret_principal(sp, &princ);
188         if(ret)
189             goto fail;
190         ret = krb5_ret_principal(sp, &princ2);
191         if(ret){
192             krb5_free_principal(contextp->context, princ);
193             goto fail;
194         }
195         krb5_unparse_name_fixed(contextp->context, princ, name, sizeof(name));
196         krb5_unparse_name_fixed(contextp->context, princ2, name2, sizeof(name2));
197         krb5_warnx(contextp->context, "%s: %s %s -> %s",
198                    client, op, name, name2);
199         ret = _kadm5_acl_check_permission(contextp,
200                                           KADM5_PRIV_ADD,
201                                           princ2)
202             || _kadm5_acl_check_permission(contextp,
203                                            KADM5_PRIV_DELETE,
204                                            princ);
205         if(ret){
206             krb5_free_principal(contextp->context, princ);
207             krb5_free_principal(contextp->context, princ2);
208             goto fail;
209         }
210         ret = kadm5_rename_principal(kadm_handlep, princ, princ2);
211         krb5_free_principal(contextp->context, princ);
212         krb5_free_principal(contextp->context, princ2);
213         krb5_storage_free(sp);
214         sp = krb5_storage_emem();
215         krb5_store_int32(sp, ret);
216         break;
217     }
218     case kadm_chpass:{
219         op = "CHPASS";
220         ret = krb5_ret_principal(sp, &princ);
221         if (ret)
222             goto fail;
223         ret = krb5_ret_string(sp, &password);
224         if (ret) {
225             krb5_free_principal(contextp->context, princ);
226             goto fail;
227         }
228         ret = krb5_ret_int32(sp, &keepold);
229         if (ret && ret != HEIM_ERR_EOF) {
230             krb5_free_principal(contextp->context, princ);
231             goto fail;
232         }
233         krb5_unparse_name_fixed(contextp->context, princ, name, sizeof(name));
234         krb5_warnx(contextp->context, "%s: %s %s", client, op, name);
235
236         /*
237          * The change is allowed if at least one of:
238
239          * a) it's for the principal him/herself and this was an
240          *    initial ticket, but then, check with the password quality
241          *    function.
242          * b) the user is on the CPW ACL.
243          */
244
245         if (initial
246             && krb5_principal_compare (contextp->context, contextp->caller,
247                                        princ))
248         {
249             krb5_data pwd_data;
250             const char *pwd_reason;
251
252             pwd_data.data = password;
253             pwd_data.length = strlen(password);
254
255             pwd_reason = kadm5_check_password_quality (contextp->context,
256                                                        princ, &pwd_data);
257             if (pwd_reason != NULL)
258                 ret = KADM5_PASS_Q_DICT;
259             else
260                 ret = 0;
261         } else
262             ret = _kadm5_acl_check_permission(contextp, KADM5_PRIV_CPW, princ);
263
264         if(ret) {
265             krb5_free_principal(contextp->context, princ);
266             memset(password, 0, strlen(password));
267             free(password);
268             goto fail;
269         }
270         ret = kadm5_chpass_principal_3(kadm_handlep, princ, keepold, 0, NULL,
271                                        password);
272         krb5_free_principal(contextp->context, princ);
273         memset(password, 0, strlen(password));
274         free(password);
275         krb5_storage_free(sp);
276         sp = krb5_storage_emem();
277         krb5_store_int32(sp, ret);
278         break;
279     }
280     case kadm_chpass_with_key:{
281         int i;
282         krb5_key_data *key_data;
283         int n_key_data;
284
285         op = "CHPASS_WITH_KEY";
286         ret = krb5_ret_principal(sp, &princ);
287         if(ret)
288             goto fail;
289         ret = krb5_ret_int32(sp, &n_key_data);
290         if (ret) {
291             krb5_free_principal(contextp->context, princ);
292             goto fail;
293         }
294         ret = krb5_ret_int32(sp, &keepold);
295         if (ret && ret != HEIM_ERR_EOF) {
296             krb5_free_principal(contextp->context, princ);
297             goto fail;
298         }
299         /* n_key_data will be squeezed into an int16_t below. */
300         if (n_key_data < 0 || n_key_data >= 1 << 16 ||
301             (size_t)n_key_data > UINT_MAX/sizeof(*key_data)) {
302             ret = ERANGE;
303             krb5_free_principal(contextp->context, princ);
304             goto fail;
305         }
306
307         key_data = malloc (n_key_data * sizeof(*key_data));
308         if (key_data == NULL && n_key_data != 0) {
309             ret = ENOMEM;
310             krb5_free_principal(contextp->context, princ);
311             goto fail;
312         }
313
314         for (i = 0; i < n_key_data; ++i) {
315             ret = kadm5_ret_key_data (sp, &key_data[i]);
316             if (ret) {
317                 int16_t dummy = i;
318
319                 kadm5_free_key_data (contextp, &dummy, key_data);
320                 free (key_data);
321                 krb5_free_principal(contextp->context, princ);
322                 goto fail;
323             }
324         }
325
326         krb5_unparse_name_fixed(contextp->context, princ, name, sizeof(name));
327         krb5_warnx(contextp->context, "%s: %s %s", client, op, name);
328
329         /*
330          * The change is only allowed if the user is on the CPW ACL,
331          * this it to force password quality check on the user.
332          */
333
334         ret = _kadm5_acl_check_permission(contextp, KADM5_PRIV_CPW, princ);
335         if(ret) {
336             int16_t dummy = n_key_data;
337
338             kadm5_free_key_data (contextp, &dummy, key_data);
339             free (key_data);
340             krb5_free_principal(contextp->context, princ);
341             goto fail;
342         }
343         ret = kadm5_chpass_principal_with_key_3(kadm_handlep, princ, keepold,
344                                                 n_key_data, key_data);
345         {
346             int16_t dummy = n_key_data;
347             kadm5_free_key_data (contextp, &dummy, key_data);
348         }
349         free (key_data);
350         krb5_free_principal(contextp->context, princ);
351         krb5_storage_free(sp);
352         sp = krb5_storage_emem();
353         krb5_store_int32(sp, ret);
354         break;
355     }
356     case kadm_randkey:{
357         op = "RANDKEY";
358         ret = krb5_ret_principal(sp, &princ);
359         if(ret)
360             goto fail;
361         krb5_unparse_name_fixed(contextp->context, princ, name, sizeof(name));
362         krb5_warnx(contextp->context, "%s: %s %s", client, op, name);
363         /*
364          * The change is allowed if at least one of:
365          * a) it's for the principal him/herself and this was an initial ticket
366          * b) the user is on the CPW ACL.
367          */
368
369         if (initial
370             && krb5_principal_compare (contextp->context, contextp->caller,
371                                        princ))
372             ret = 0;
373         else
374             ret = _kadm5_acl_check_permission(contextp, KADM5_PRIV_CPW, princ);
375
376         if(ret) {
377             krb5_free_principal(contextp->context, princ);
378             goto fail;
379         }
380
381         /*
382          * See comments in kadm5_c_randkey_principal() regarding the
383          * protocol.
384          */
385         ret = krb5_ret_int32(sp, &keepold);
386         if (ret != 0 && ret != HEIM_ERR_EOF) {
387             krb5_free_principal(contextp->context, princ);
388             goto fail;
389         }
390
391         ret = krb5_ret_int32(sp, &n_ks_tuple);
392         if (ret != 0 && ret != HEIM_ERR_EOF) {
393             krb5_free_principal(contextp->context, princ);
394             goto fail;
395         } else if (ret == 0) {
396             size_t i;
397
398             if (n_ks_tuple < 0) {
399                 ret = EOVERFLOW;
400                 krb5_free_principal(contextp->context, princ);
401                 goto fail;
402             }
403
404             if ((ks_tuple = calloc(n_ks_tuple, sizeof (*ks_tuple))) == NULL) {
405                 ret = errno;
406                 krb5_free_principal(contextp->context, princ);
407                 goto fail;
408             }
409
410             for (i = 0; i < n_ks_tuple; i++) {
411                 ret = krb5_ret_int32(sp, &ks_tuple[i].ks_enctype);
412                 if (ret != 0) {
413                     krb5_free_principal(contextp->context, princ);
414                     goto fail;
415                 }
416                 ret = krb5_ret_int32(sp, &ks_tuple[i].ks_salttype);
417                 if (ret != 0) {
418                     krb5_free_principal(contextp->context, princ);
419                     goto fail;
420                 }
421             }
422         }
423         ret = kadm5_randkey_principal_3(kadm_handlep, princ, keepold,
424                                         n_ks_tuple, ks_tuple, &new_keys,
425                                         &n_keys);
426         krb5_free_principal(contextp->context, princ);
427
428         krb5_storage_free(sp);
429         sp = krb5_storage_emem();
430         krb5_store_int32(sp, ret);
431         if(ret == 0){
432             int i;
433             krb5_store_int32(sp, n_keys);
434             for(i = 0; i < n_keys; i++){
435                 krb5_store_keyblock(sp, new_keys[i]);
436                 krb5_free_keyblock_contents(contextp->context, &new_keys[i]);
437             }
438             free(new_keys);
439         }
440         break;
441     }
442     case kadm_get_privs:{
443         uint32_t privs;
444         ret = kadm5_get_privs(kadm_handlep, &privs);
445         krb5_storage_free(sp);
446         sp = krb5_storage_emem();
447         krb5_store_int32(sp, ret);
448         if(ret == 0)
449             krb5_store_uint32(sp, privs);
450         break;
451     }
452     case kadm_get_princs:{
453         op = "LIST";
454         ret = krb5_ret_int32(sp, &tmp);
455         if(ret)
456             goto fail;
457         if(tmp){
458             ret = krb5_ret_string(sp, &expression);
459             if(ret)
460                 goto fail;
461         }else
462             expression = NULL;
463         krb5_warnx(contextp->context, "%s: %s %s", client, op,
464                    expression ? expression : "*");
465         ret = _kadm5_acl_check_permission(contextp, KADM5_PRIV_LIST, NULL);
466         if(ret){
467             free(expression);
468             goto fail;
469         }
470         ret = kadm5_get_principals(kadm_handlep, expression, &princs, &n_princs);
471         free(expression);
472         krb5_storage_free(sp);
473         sp = krb5_storage_emem();
474         krb5_store_int32(sp, ret);
475         if(ret == 0){
476             int i;
477             krb5_store_int32(sp, n_princs);
478             for(i = 0; i < n_princs; i++)
479                 krb5_store_string(sp, princs[i]);
480             kadm5_free_name_list(kadm_handlep, princs, &n_princs);
481         }
482         break;
483     }
484     default:
485         krb5_warnx(contextp->context, "%s: UNKNOWN OP %d", client, cmd);
486         krb5_storage_free(sp);
487         sp = krb5_storage_emem();
488         krb5_store_int32(sp, KADM5_FAILURE);
489         break;
490     }
491     krb5_storage_to_data(sp, out);
492     krb5_storage_free(sp);
493     return 0;
494 fail:
495     krb5_warn(contextp->context, ret, "%s", op);
496     krb5_storage_seek(sp, 0, SEEK_SET);
497     krb5_store_int32(sp, ret);
498     krb5_storage_to_data(sp, out);
499     krb5_storage_free(sp);
500     return 0;
501 }
502
503 static void
504 v5_loop (krb5_context contextp,
505          krb5_auth_context ac,
506          krb5_boolean initial,
507          void *kadm_handlep,
508          krb5_socket_t fd)
509 {
510     krb5_error_code ret;
511     krb5_data in, out;
512
513     for (;;) {
514         doing_useful_work = 0;
515         if(term_flag)
516             exit(0);
517         ret = krb5_read_priv_message(contextp, ac, &fd, &in);
518         if(ret == HEIM_ERR_EOF)
519             exit(0);
520         if(ret)
521             krb5_err(contextp, 1, ret, "krb5_read_priv_message");
522         doing_useful_work = 1;
523         kadmind_dispatch(kadm_handlep, initial, &in, &out);
524         krb5_data_free(&in);
525         ret = krb5_write_priv_message(contextp, ac, &fd, &out);
526         if(ret)
527             krb5_err(contextp, 1, ret, "krb5_write_priv_message");
528     }
529 }
530
531 static krb5_boolean
532 match_appl_version(const void *data, const char *appl_version)
533 {
534     unsigned minor;
535     if(sscanf(appl_version, "KADM0.%u", &minor) != 1)
536         return 0;
537     /*XXX*/
538     *(unsigned*)(intptr_t)data = minor;
539     return 1;
540 }
541
542 static void
543 handle_v5(krb5_context contextp,
544           krb5_keytab keytab,
545           krb5_socket_t fd)
546 {
547     krb5_error_code ret;
548     krb5_ticket *ticket;
549     char *server_name;
550     char *client;
551     void *kadm_handlep;
552     krb5_boolean initial;
553     krb5_auth_context ac = NULL;
554
555     unsigned kadm_version;
556     kadm5_config_params realm_params;
557
558     ret = krb5_recvauth_match_version(contextp, &ac, &fd,
559                                       match_appl_version, &kadm_version,
560                                       NULL, KRB5_RECVAUTH_IGNORE_VERSION,
561                                       keytab, &ticket);
562     if (ret)
563         krb5_err(contextp, 1, ret, "krb5_recvauth");
564
565     ret = krb5_unparse_name (contextp, ticket->server, &server_name);
566     if (ret)
567         krb5_err (contextp, 1, ret, "krb5_unparse_name");
568
569     if (strncmp (server_name, KADM5_ADMIN_SERVICE,
570                  strlen(KADM5_ADMIN_SERVICE)) != 0)
571         krb5_errx (contextp, 1, "ticket for strange principal (%s)",
572                    server_name);
573
574     free (server_name);
575
576     memset(&realm_params, 0, sizeof(realm_params));
577
578     if(kadm_version == 1) {
579         krb5_data params;
580         ret = krb5_read_priv_message(contextp, ac, &fd, &params);
581         if(ret)
582             krb5_err(contextp, 1, ret, "krb5_read_priv_message");
583         _kadm5_unmarshal_params(contextp, &params, &realm_params);
584     }
585
586     initial = ticket->ticket.flags.initial;
587     ret = krb5_unparse_name(contextp, ticket->client, &client);
588     if (ret)
589         krb5_err (contextp, 1, ret, "krb5_unparse_name");
590     krb5_free_ticket (contextp, ticket);
591     ret = kadm5_s_init_with_password_ctx(contextp,
592                                          client,
593                                          NULL,
594                                          KADM5_ADMIN_SERVICE,
595                                          &realm_params,
596                                          0, 0,
597                                          &kadm_handlep);
598     if(ret)
599         krb5_err (contextp, 1, ret, "kadm5_init_with_password_ctx");
600     v5_loop (contextp, ac, initial, kadm_handlep, fd);
601 }
602
603 krb5_error_code
604 kadmind_loop(krb5_context contextp,
605              krb5_keytab keytab,
606              krb5_socket_t sock)
607 {
608     u_char buf[sizeof(KRB5_SENDAUTH_VERSION) + 4];
609     ssize_t n;
610     unsigned long len;
611
612     n = krb5_net_read(contextp, &sock, buf, 4);
613     if(n == 0)
614         exit(0);
615     if(n < 0)
616         krb5_err(contextp, 1, errno, "read");
617     _krb5_get_int(buf, &len, 4);
618
619     if (len == sizeof(KRB5_SENDAUTH_VERSION)) {
620
621         n = krb5_net_read(contextp, &sock, buf + 4, len);
622         if (n < 0)
623             krb5_err (contextp, 1, errno, "reading sendauth version");
624         if (n == 0)
625             krb5_errx (contextp, 1, "EOF reading sendauth version");
626
627         if(memcmp(buf + 4, KRB5_SENDAUTH_VERSION, len) == 0) {
628             handle_v5(contextp, keytab, sock);
629             return 0;
630         }
631         len += 4;
632     } else
633         len = 4;
634
635     handle_mit(contextp, buf, len, sock);
636
637     return 0;
638 }