pr-initialize-dont-leak-ref-20041009
[openafs.git] / src / ptserver / ptuser.c
1 /*
2  * Copyright 2000, International Business Machines Corporation and others.
3  * All Rights Reserved.
4  * 
5  * This software has been released under the terms of the IBM Public
6  * License.  For details, see the LICENSE file in the top-level source
7  * directory or online at http://www.openafs.org/dl/license10.html
8  */
9
10 #include <afsconfig.h>
11 #if defined(UKERNEL)
12 #include "afs/param.h"
13 #else
14 #include <afs/param.h>
15 #endif
16
17 RCSID
18     ("$Header$");
19
20 #if defined(UKERNEL)
21 #include "afs/sysincludes.h"
22 #include "afs_usrops.h"
23 #include "afsincludes.h"
24 #include "afs/stds.h"
25 #include "rx/rx.h"
26 #include "rx/xdr.h"
27 #include "rx/rxkad.h"
28 #include "afs/auth.h"
29 #include "afs/cellconfig.h"
30 #include "afs/afsutil.h"
31 #include "afs/ptclient.h"
32 #include "afs/pterror.h"
33 #else /* defined(UKERNEL) */
34 #include <afs/stds.h>
35 #include <ctype.h>
36 #include <sys/types.h>
37 #ifdef AFS_NT40_ENV
38 #include <winsock2.h>
39 #else
40 #include <netinet/in.h>
41 #endif
42 #include <stdio.h>
43 #ifdef HAVE_STRING_H
44 #include <string.h>
45 #else
46 #ifdef HAVE_STRINGS_H
47 #include <strings.h>
48 #endif
49 #endif
50 #include <rx/rx.h>
51 #include <rx/xdr.h>
52 #include <rx/rxkad.h>
53 #include <afs/auth.h>
54 #include <afs/cellconfig.h>
55 #include <afs/afsutil.h>
56 #include "ptclient.h"
57 #include "pterror.h"
58 #endif /* defined(UKERNEL) */
59
60
61 struct ubik_client *pruclient = 0;
62 static afs_int32 lastLevel;     /* security level pruclient, if any */
63
64 static char *whoami = "libprot";
65
66 afs_int32
67 pr_Initialize(IN afs_int32 secLevel, IN char *confDir, IN char *cell)
68 {
69     afs_int32 code;
70     struct rx_connection *serverconns[MAXSERVERS];
71     struct rx_securityClass *sc[3];
72     static struct afsconf_dir *tdir = 0;        /* only do this once */
73     static char tconfDir[100];
74     struct ktc_token ttoken;
75     afs_int32 scIndex;
76     static struct afsconf_cell info;
77     afs_int32 i;
78     char cellstr[64];
79
80     initialize_PT_error_table();
81     initialize_RXK_error_table();
82     initialize_ACFG_error_table();
83     initialize_KTC_error_table();
84
85     if (strcmp(confDir, tconfDir)) {
86         /*
87          * Different conf dir; force re-evaluation.
88          */
89         if (tdir) 
90             afsconf_Close(tdir);
91         tdir = (struct afsconf_dir *)0;
92         pruclient = (struct ubik_client *)0;
93     }
94     if (tdir == 0) {
95         strncpy(tconfDir, confDir, sizeof(tconfDir));
96 #if defined(UKERNEL)
97         tdir = afs_cdir;
98         if (!cell) {
99             cell = afs_LclCellName;
100         }
101 #else /* defined(UKERNEL) */
102         tdir = afsconf_Open(confDir);
103         if (!tdir) {
104             if (confDir && strcmp(confDir, ""))
105                 fprintf(stderr,
106                         "libprot: Could not open configuration directory: %s.\n",
107                         confDir);
108             return -1;
109         }
110
111         if (!cell) {
112             code = afsconf_GetLocalCell(tdir, cellstr, sizeof(cellstr));
113             if (code) {
114                 fprintf(stderr,
115                         "vos: can't get local cell name - check %s/%s\n",
116                         confDir, AFSDIR_THISCELL_FILE);
117                 exit(1);
118             }
119             cell = cellstr;
120         }
121 #endif /* defined(UKERNEL) */
122
123         code = afsconf_GetCellInfo(tdir, cell, "afsprot", &info);
124         if (code) {
125             fprintf(stderr, "libprot: Could not locate cell %s in %s/%s\n",
126                     cell, confDir, AFSDIR_CELLSERVDB_FILE);
127             return code;
128         }
129     }
130
131     /* If we already have a client and it is at the security level we
132      * want, don't get a new one. Unless the security level is 2 in
133      * which case we will get one (and re-read the key file).
134      */
135     if (pruclient && (lastLevel == secLevel) && (secLevel != 2))
136         return 0;
137
138     code = rx_Init(0);
139     if (code) {
140         fprintf(stderr, "libprot:  Could not initialize rx.\n");
141         return code;
142     }
143
144     scIndex = secLevel;
145     sc[0] = 0;
146     sc[1] = 0;
147     sc[2] = 0;
148     /* Most callers use secLevel==1, however, the fileserver uses secLevel==2
149      * to force use of the KeyFile.  secLevel == 0 implies -noauth was
150      * specified. */
151     if ((secLevel == 2) && (afsconf_GetLatestKey(tdir, 0, 0) == 0)) {
152         /* If secLevel is two assume we're on a file server and use
153          * ClientAuthSecure if possible. */
154         code = afsconf_ClientAuthSecure(tdir, &sc[2], &scIndex);
155         if (code)
156             fprintf(stderr,
157                     "libprot: clientauthsecure returns %d %s"
158                     " (so trying noauth)\n", code, error_message(code));
159         if (code)
160             scIndex = 0;        /* use noauth */
161         if (scIndex != 2)
162             /* if there was a problem, an unauthenticated conn is returned */
163             sc[scIndex] = sc[2];
164     } else if (secLevel > 0) {
165         struct ktc_principal sname;
166         strcpy(sname.cell, info.name);
167         sname.instance[0] = 0;
168         strcpy(sname.name, "afs");
169         code = ktc_GetToken(&sname, &ttoken, sizeof(ttoken), NULL);
170         if (code)
171             scIndex = 0;
172         else {
173             if (ttoken.kvno >= 0 && ttoken.kvno <= 256)
174                 /* this is a kerberos ticket, set scIndex accordingly */
175                 scIndex = 2;
176             else {
177                 fprintf(stderr,
178                         "libprot: funny kvno (%d) in ticket, proceeding\n",
179                         ttoken.kvno);
180                 scIndex = 2;
181             }
182             sc[2] =
183                 rxkad_NewClientSecurityObject(rxkad_clear, &ttoken.sessionKey,
184                                               ttoken.kvno, ttoken.ticketLen,
185                                               ttoken.ticket);
186         }
187     }
188     if (scIndex == 1)
189         return PRBADARG;
190     if ((scIndex == 0) && (sc[0] == 0))
191         sc[0] = rxnull_NewClientSecurityObject();
192     if ((scIndex == 0) && (secLevel != 0))
193         com_err(whoami, code,
194                 "Could not get afs tokens, running unauthenticated.");
195
196     memset(serverconns, 0, sizeof(serverconns));        /* terminate list!!! */
197     for (i = 0; i < info.numServers; i++)
198         serverconns[i] =
199             rx_NewConnection(info.hostAddr[i].sin_addr.s_addr,
200                              info.hostAddr[i].sin_port, PRSRV, sc[scIndex],
201                              scIndex);
202
203     code = ubik_ClientInit(serverconns, &pruclient);
204     if (code) {
205         com_err(whoami, code, "ubik client init failed.");
206         return code;
207     }
208     lastLevel = scIndex;
209
210     code = rxs_Release(sc[scIndex]);
211     return code;
212 }
213
214 int
215 pr_End()
216 {
217     int code = 0;
218
219     if (pruclient) {
220         code = ubik_ClientDestroy(pruclient);
221         pruclient = 0;
222     }
223     return code;
224 }
225
226
227
228 int
229 pr_CreateUser(char name[PR_MAXNAMELEN], afs_int32 *id)
230 {
231     register afs_int32 code;
232
233     stolower(name);
234     if (*id) {
235         code = ubik_Call(PR_INewEntry, pruclient, 0, name, *id, 0);
236         return code;
237     } else {
238         code = ubik_Call(PR_NewEntry, pruclient, 0, name, 0, 0, id);
239         return code;
240     }
241
242 }
243
244 int 
245 pr_CreateGroup(char name[PR_MAXNAMELEN], char owner[PR_MAXNAMELEN], afs_int32 *id)
246 {
247     register afs_int32 code;
248     afs_int32 oid = 0;
249     afs_int32 flags = 0;
250
251     stolower(name);
252     if (owner) {
253         code = pr_SNameToId(owner, &oid);
254         if (code)
255             return code;
256         if (oid == ANONYMOUSID)
257             return PRNOENT;
258     }
259     flags |= PRGRP;
260     if (*id) {
261         code = ubik_Call(PR_INewEntry, pruclient, 0, name, *id, oid);
262         return code;
263     } else {
264         code = ubik_Call(PR_NewEntry, pruclient, 0, name, flags, oid, id);
265         return code;
266     }
267 }
268
269 int
270 pr_Delete(char *name)
271 {
272     register afs_int32 code;
273     afs_int32 id;
274
275     stolower(name);
276     code = pr_SNameToId(name, &id);
277     if (code)
278         return code;
279     if (id == ANONYMOUSID)
280         return PRNOENT;
281     code = ubik_Call(PR_Delete, pruclient, 0, id);
282     return code;
283 }
284
285 int
286 pr_DeleteByID(afs_int32 id)
287 {
288     register afs_int32 code;
289
290     code = ubik_Call(PR_Delete, pruclient, 0, id);
291     return code;
292 }
293
294 int
295 pr_AddToGroup(char *user, char *group)
296 {
297     register afs_int32 code;
298     namelist lnames;
299     idlist lids;
300
301     lnames.namelist_len = 2;
302     lnames.namelist_val = (prname *) malloc(2 * PR_MAXNAMELEN);
303     strncpy(lnames.namelist_val[0], user, PR_MAXNAMELEN);
304     strncpy(lnames.namelist_val[1], group, PR_MAXNAMELEN);
305     lids.idlist_val = 0;
306     lids.idlist_len = 0;
307     code = pr_NameToId(&lnames, &lids);
308     if (code)
309         goto done;
310     /* if here, still could be missing an entry */
311     if (lids.idlist_val[0] == ANONYMOUSID
312         || lids.idlist_val[1] == ANONYMOUSID) {
313         code = PRNOENT;
314         goto done;
315     }
316     code =
317         ubik_Call(PR_AddToGroup, pruclient, 0, lids.idlist_val[0],
318                   lids.idlist_val[1]);
319   done:
320     if (lnames.namelist_val)
321         free(lnames.namelist_val);
322     if (lids.idlist_val)
323         free(lids.idlist_val);
324     return code;
325 }
326
327 int
328 pr_RemoveUserFromGroup(char *user, char *group)
329 {
330     register afs_int32 code;
331     namelist lnames;
332     idlist lids;
333
334     lnames.namelist_len = 2;
335     lnames.namelist_val = (prname *) malloc(2 * PR_MAXNAMELEN);
336     strncpy(lnames.namelist_val[0], user, PR_MAXNAMELEN);
337     strncpy(lnames.namelist_val[1], group, PR_MAXNAMELEN);
338     lids.idlist_val = 0;
339     lids.idlist_len = 0;
340     code = pr_NameToId(&lnames, &lids);
341     if (code)
342         goto done;
343
344     if (lids.idlist_val[0] == ANONYMOUSID
345         || lids.idlist_val[1] == ANONYMOUSID) {
346         code = PRNOENT;
347         goto done;
348     }
349     code =
350         ubik_Call(PR_RemoveFromGroup, pruclient, 0, lids.idlist_val[0],
351                   lids.idlist_val[1]);
352   done:
353     if (lnames.namelist_val)
354         free(lnames.namelist_val);
355     if (lids.idlist_val)
356         free(lids.idlist_val);
357     return code;
358
359 }
360
361 int
362 pr_NameToId(namelist *names, idlist *ids)
363 {
364     register afs_int32 code;
365     register afs_int32 i;
366
367     for (i = 0; i < names->namelist_len; i++)
368         stolower(names->namelist_val[i]);
369     code = ubik_Call(PR_NameToID, pruclient, 0, names, ids);
370     return code;
371 }
372
373 int
374 pr_SNameToId(char name[PR_MAXNAMELEN], afs_int32 *id)
375 {
376     namelist lnames;
377     idlist lids;
378     register afs_int32 code;
379
380     lids.idlist_len = 0;
381     lids.idlist_val = 0;
382     lnames.namelist_len = 1;
383     lnames.namelist_val = (prname *) malloc(PR_MAXNAMELEN);
384     stolower(name);
385     strncpy(lnames.namelist_val[0], name, PR_MAXNAMELEN);
386     code = ubik_Call(PR_NameToID, pruclient, 0, &lnames, &lids);
387     if (lids.idlist_val) {
388         *id = *lids.idlist_val;
389         free(lids.idlist_val);
390     }
391     if (lnames.namelist_val)
392         free(lnames.namelist_val);
393     return code;
394 }
395
396 int
397 pr_IdToName(idlist *ids, namelist *names)
398 {
399     register afs_int32 code;
400
401     code = ubik_Call(PR_IDToName, pruclient, 0, ids, names);
402     return code;
403 }
404
405 int
406 pr_SIdToName(afs_int32 id, char name[PR_MAXNAMELEN])
407 {
408     namelist lnames;
409     idlist lids;
410     register afs_int32 code;
411
412     lids.idlist_len = 1;
413     lids.idlist_val = (afs_int32 *) malloc(sizeof(afs_int32));
414     *lids.idlist_val = id;
415     lnames.namelist_len = 0;
416     lnames.namelist_val = 0;
417     code = ubik_Call(PR_IDToName, pruclient, 0, &lids, &lnames);
418     if (lnames.namelist_val) {
419         strncpy(name, lnames.namelist_val[0], PR_MAXNAMELEN);
420         free(lnames.namelist_val);
421     }
422     if (lids.idlist_val)
423         free(lids.idlist_val);
424     return code;
425 }
426
427 int
428 pr_GetCPS(afs_int32 id, prlist *CPS)
429 {
430     register afs_int32 code;
431     afs_int32 over;
432
433     over = 0;
434     code = ubik_Call(PR_GetCPS, pruclient, 0, id, CPS, &over);
435     if (code != PRSUCCESS)
436         return code;
437     if (over) {
438         /* do something about this, probably make a new call */
439         /* don't forget there's a hard limit in the interface */
440         fprintf(stderr, "membership list for id %d exceeds display limit\n",
441                 id);
442     }
443     return 0;
444 }
445
446 int
447 pr_GetCPS2(afs_int32 id, afs_int32 host, prlist *CPS)
448 {
449     register afs_int32 code;
450     afs_int32 over;
451
452     over = 0;
453     code = ubik_Call(PR_GetCPS2, pruclient, 0, id, host, CPS, &over);
454     if (code != PRSUCCESS)
455         return code;
456     if (over) {
457         /* do something about this, probably make a new call */
458         /* don't forget there's a hard limit in the interface */
459         fprintf(stderr, "membership list for id %d exceeds display limit\n",
460                 id);
461     }
462     return 0;
463 }
464
465 int
466 pr_GetHostCPS(afs_int32 host, prlist *CPS)
467 {
468     register afs_int32 code;
469     afs_int32 over;
470
471     over = 0;
472     code = ubik_Call(PR_GetHostCPS, pruclient, 0, host, CPS, &over);
473     if (code != PRSUCCESS)
474         return code;
475     if (over) {
476         /* do something about this, probably make a new call */
477         /* don't forget there's a hard limit in the interface */
478         fprintf(stderr,
479                 "membership list for host id %d exceeds display limit\n",
480                 host);
481     }
482     return 0;
483 }
484
485 int
486 pr_ListMembers(char *group, namelist *lnames)
487 {
488     register afs_int32 code;
489     afs_int32 gid;
490
491     code = pr_SNameToId(group, &gid);
492     if (code)
493         return code;
494     if (gid == ANONYMOUSID)
495         return PRNOENT;
496     code = pr_IDListMembers(gid, lnames);
497     return code;
498 }
499
500 int
501 pr_ListOwned(afs_int32 oid, namelist *lnames, afs_int32 *moreP)
502 {
503     register afs_int32 code;
504     prlist alist;
505     idlist *lids;
506
507     alist.prlist_len = 0;
508     alist.prlist_val = 0;
509     code = ubik_Call(PR_ListOwned, pruclient, 0, oid, &alist, moreP);
510     if (code)
511         return code;
512     if (*moreP == 1) {
513         /* Remain backwards compatible when moreP was a T/F bit */
514         fprintf(stderr, "membership list for id %d exceeds display limit\n",
515                 oid);
516         *moreP = 0;
517     }
518     lids = (idlist *) & alist;
519     code = pr_IdToName(lids, lnames);
520     if (code)
521         return code;
522     if (alist.prlist_val)
523         free(alist.prlist_val);
524     return PRSUCCESS;
525 }
526
527 int
528 pr_IDListMembers(afs_int32 gid, namelist *lnames)
529 {
530     register afs_int32 code;
531     prlist alist;
532     idlist *lids;
533     afs_int32 over;
534
535     alist.prlist_len = 0;
536     alist.prlist_val = 0;
537     code = ubik_Call(PR_ListElements, pruclient, 0, gid, &alist, &over);
538     if (code)
539         return code;
540     if (over) {
541         fprintf(stderr, "membership list for id %d exceeds display limit\n",
542                 gid);
543     }
544     lids = (idlist *) & alist;
545     code = pr_IdToName(lids, lnames);
546     if (code)
547         return code;
548     if (alist.prlist_val)
549         free(alist.prlist_val);
550     return PRSUCCESS;
551 }
552
553 int
554 pr_ListEntry(afs_int32 id, struct prcheckentry *aentry)
555 {
556     register afs_int32 code;
557
558     code = ubik_Call(PR_ListEntry, pruclient, 0, id, aentry);
559     return code;
560 }
561
562 afs_int32
563 pr_ListEntries(int flag, afs_int32 startindex, afs_int32 *nentries, struct prlistentries **entries, afs_int32 *nextstartindex)
564 {
565     afs_int32 code;
566     prentries bulkentries;
567
568     *nentries = 0;
569     *entries = NULL;
570     *nextstartindex = -1;
571     bulkentries.prentries_val = 0;
572     bulkentries.prentries_len = 0;
573
574     code =
575         ubik_Call(PR_ListEntries, pruclient, 0, flag, startindex,
576                   &bulkentries, nextstartindex);
577     *nentries = bulkentries.prentries_len;
578     *entries = bulkentries.prentries_val;
579     return code;
580 }
581
582 int
583 pr_CheckEntryByName(char *name, afs_int32 *id, char *owner, char *creator)
584 {
585     /* struct prcheckentry returns other things, which aren't useful to show at this time. */
586     register afs_int32 code;
587     struct prcheckentry aentry;
588
589     code = pr_SNameToId(name, id);
590     if (code)
591         return code;
592     if (*id == ANONYMOUSID)
593         return PRNOENT;
594     code = ubik_Call(PR_ListEntry, pruclient, 0, *id, &aentry);
595     if (code)
596         return code;
597     /* this should be done in one RPC, but I'm lazy. */
598     code = pr_SIdToName(aentry.owner, owner);
599     if (code)
600         return code;
601     code = pr_SIdToName(aentry.creator, creator);
602     if (code)
603         return code;
604     return PRSUCCESS;
605 }
606
607 int
608 pr_CheckEntryById(char *name, afs_int32 id, char *owner, char *creator)
609 {
610     /* struct prcheckentry returns other things, which aren't useful to show at this time. */
611     register afs_int32 code;
612     struct prcheckentry aentry;
613
614     code = pr_SIdToName(id, name);
615     if (code)
616         return code;
617     if (id == ANONYMOUSID)
618         return PRNOENT;
619     code = ubik_Call(PR_ListEntry, pruclient, 0, id, &aentry);
620     if (code)
621         return code;
622     /* this should be done in one RPC, but I'm lazy. */
623     code = pr_SIdToName(aentry.owner, owner);
624     if (code)
625         return code;
626     code = pr_SIdToName(aentry.creator, creator);
627     if (code)
628         return code;
629     return PRSUCCESS;
630 }
631
632 int
633 pr_ChangeEntry(char *oldname, char *newname, afs_int32 *newid, char *newowner)
634 {
635     register afs_int32 code;
636     afs_int32 id;
637     afs_int32 oid = 0;
638
639     code = pr_SNameToId(oldname, &id);
640     if (code)
641         return code;
642     if (id == ANONYMOUSID)
643         return PRNOENT;
644     if (newowner && *newowner) {
645         code = pr_SNameToId(newowner, &oid);
646         if (code)
647             return code;
648         if (oid == ANONYMOUSID)
649             return PRNOENT;
650     }
651     code = ubik_Call(PR_ChangeEntry, pruclient, 0, id, newname, oid, newid);
652     return code;
653 }
654
655 int
656 pr_IsAMemberOf(char *uname, char *gname, afs_int32 *flag)
657 {
658     register afs_int32 code;
659     namelist lnames;
660     idlist lids;
661
662     stolower(uname);
663     stolower(gname);
664     lnames.namelist_len = 2;
665     lnames.namelist_val = (prname *) malloc(2 * PR_MAXNAMELEN);
666     strncpy(lnames.namelist_val[0], uname, PR_MAXNAMELEN);
667     strncpy(lnames.namelist_val[1], gname, PR_MAXNAMELEN);
668     lids.idlist_val = 0;
669     lids.idlist_len = 0;
670     code = pr_NameToId(&lnames, &lids);
671     if (code) {
672         if (lnames.namelist_val)
673             free(lnames.namelist_val);
674         if (lids.idlist_val)
675             free(lids.idlist_val);
676         return code;
677     }
678     code =
679         ubik_Call(PR_IsAMemberOf, pruclient, 0, lids.idlist_val[0],
680                   lids.idlist_val[1], flag);
681     if (lnames.namelist_val)
682         free(lnames.namelist_val);
683     if (lids.idlist_val)
684         free(lids.idlist_val);
685     return code;
686 }
687
688 int
689 pr_ListMaxUserId(afs_int32 *mid)
690 {
691     register afs_int32 code;
692     afs_int32 gid;
693     code = ubik_Call(PR_ListMax, pruclient, 0, mid, &gid);
694     return code;
695 }
696
697 int
698 pr_SetMaxUserId(afs_int32 mid)
699 {
700     register afs_int32 code;
701     afs_int32 flag = 0;
702     code = ubik_Call(PR_SetMax, pruclient, 0, mid, flag);
703     return code;
704 }
705
706 int
707 pr_ListMaxGroupId(afs_int32 *mid)
708 {
709     register afs_int32 code;
710     afs_int32 id;
711     code = ubik_Call(PR_ListMax, pruclient, 0, &id, mid);
712     return code;
713 }
714
715 int
716 pr_SetMaxGroupId(afs_int32 mid)
717 {
718     register afs_int32 code;
719     afs_int32 flag = 0;
720
721     flag |= PRGRP;
722     code = ubik_Call(PR_SetMax, pruclient, 0, mid, flag);
723     return code;
724 }
725
726 afs_int32
727 pr_SetFieldsEntry(afs_int32 id, afs_int32 mask, afs_int32 flags, afs_int32 ngroups, afs_int32 nusers)
728 {
729     register afs_int32 code;
730
731     code =
732         ubik_Call(PR_SetFieldsEntry, pruclient, 0, id, mask, flags, ngroups,
733                   nusers, 0, 0);
734     return code;
735 }
736
737 int
738 stolower(char *s)
739 {
740     while (*s) {
741         if (isupper(*s))
742             *s = tolower(*s);
743         s++;
744     }
745     return 0;
746 }