]> arthur.barton.de Git - netatalk.git/blob - etc/afpd/auth.c
Merge branch 'v3-cleanup' into tmp/v3.0.4-alex
[netatalk.git] / etc / afpd / auth.c
1 /*
2  * Copyright (c) 1990,1993 Regents of The University of Michigan.
3  * All Rights Reserved.  See COPYRIGHT.
4  */
5
6 #ifdef HAVE_CONFIG_H
7 #include "config.h"
8 #endif /* HAVE_CONFIG_H */
9
10 #include <stdio.h>
11 #include <stdlib.h>
12 #include <errno.h>
13 #include <unistd.h>
14 #include <sys/types.h>
15 #include <sys/param.h>
16 #include <sys/stat.h>
17 #include <arpa/inet.h>
18
19 #include <atalk/afp.h>
20 #include <atalk/compat.h>
21 #include <atalk/util.h>
22 #include <limits.h>
23 #include <string.h>
24 #include <ctype.h>
25 #include <time.h>
26 #include <pwd.h>
27 #include <grp.h>
28
29 #ifdef TRU64
30 #include <netdb.h>
31 #include <arpa/inet.h>
32 #include <sia.h>
33 #include <siad.h>
34
35 extern void afp_get_cmdline( int *ac, char ***av );
36 #endif /* TRU64 */
37
38 #include <atalk/logger.h>
39 #include <atalk/server_ipc.h>
40 #include <atalk/uuid.h>
41 #include <atalk/globals.h>
42 #include <atalk/unix.h>
43
44 #include "auth.h"
45 #include "uam_auth.h"
46 #include "switch.h"
47 #include "status.h"
48 #include "fork.h"
49 #include "extattrs.h"
50 #ifdef HAVE_ACLS
51 #include "acls.h"
52 #endif
53
54 static int afp_version_index;
55 static struct uam_mod uam_modules = {NULL, NULL, &uam_modules, &uam_modules};
56 static struct uam_obj uam_login = {"", "", 0, {{NULL, NULL, NULL, NULL }}, &uam_login,
57                                    &uam_login};
58 static struct uam_obj uam_changepw = {"", "", 0, {{NULL, NULL, NULL, NULL}}, &uam_changepw,
59                                       &uam_changepw};
60
61 static struct uam_obj *afp_uam = NULL;
62
63
64 void status_versions( char *data, const DSI *dsi)
65 {
66     char                *start = data;
67     uint16_t           status;
68     int         len, num, i, count = 0;
69
70     memcpy(&status, start + AFPSTATUS_VERSOFF, sizeof(status));
71     num = sizeof( afp_versions ) / sizeof( afp_versions[ 0 ] );
72
73     for ( i = 0; i < num; i++ ) {
74         if ( !dsi && (afp_versions[ i ].av_number >= 22)) continue;
75         count++;
76     }
77     data += ntohs( status );
78     *data++ = count;
79
80     for ( i = 0; i < num; i++ ) {
81         if ( !dsi && (afp_versions[ i ].av_number >= 22)) continue;
82         len = strlen( afp_versions[ i ].av_name );
83         *data++ = len;
84         memcpy( data, afp_versions[ i ].av_name , len );
85         data += len;
86     }
87     status = htons( data - start );
88     memcpy(start + AFPSTATUS_UAMSOFF, &status, sizeof(status));
89 }
90
91 void status_uams(char *data, const char *authlist)
92 {
93     char                *start = data;
94     uint16_t           status;
95     struct uam_obj      *uams;
96     int         len, num = 0;
97
98     memcpy(&status, start + AFPSTATUS_UAMSOFF, sizeof(status));
99     uams = &uam_login;
100     while ((uams = uams->uam_prev) != &uam_login) {
101         if (strstr(authlist, uams->uam_path))
102             num++;
103     }
104
105     data += ntohs( status );
106     *data++ = num;
107     while ((uams = uams->uam_prev) != &uam_login) {
108         if (strstr(authlist, uams->uam_path)) {
109             LOG(log_info, logtype_afpd, "uam: \"%s\" available", uams->uam_name);
110             len = strlen( uams->uam_name);
111             *data++ = len;
112             memcpy( data, uams->uam_name, len );
113             data += len;
114         }
115     }
116
117     /* icon offset */
118     status = htons(data - start);
119     memcpy(start + AFPSTATUS_ICONOFF, &status, sizeof(status));
120 }
121
122 /* handle errors by closing the connection. this is only needed
123  * by the afp_* functions. */
124 static int send_reply(const AFPObj *obj, const int err)
125 {
126     if ((err == AFP_OK) || (err == AFPERR_AUTHCONT))
127         return err;
128
129     obj->reply(obj->dsi, err);
130     obj->exit(0);
131
132     return AFP_OK;
133 }
134
135 static int afp_errpwdexpired(AFPObj *obj _U_, char *ibuf _U_, size_t ibuflen _U_, 
136                              char *rbuf _U_, size_t *rbuflen)
137 {
138     *rbuflen = 0;
139     return AFPERR_PWDEXPR;
140 }
141
142 static int afp_null_nolog(AFPObj *obj _U_, char *ibuf _U_, size_t ibuflen _U_, 
143                           char *rbuf _U_, size_t *rbuflen)
144 {
145     *rbuflen = 0;
146     return( AFPERR_NOOP );
147 }
148
149 static int set_auth_switch(const AFPObj *obj, int expired)
150 {
151     int i;
152
153     if (expired) {
154         /*
155          * BF: expired password handling
156          * to allow the user to change his/her password we have to allow login
157          * but every following call except for FPChangePassword will be thrown
158          * away with an AFPERR_PWDEXPR error. (thanks to Leland Wallace from Apple
159          * for clarifying this)
160          */
161
162         for (i=0; i<=0xff; i++) {
163             uam_afpserver_action(i, UAM_AFPSERVER_PREAUTH, afp_errpwdexpired, NULL);
164         }
165         uam_afpserver_action(AFP_LOGOUT, UAM_AFPSERVER_PREAUTH, afp_logout, NULL);
166         uam_afpserver_action(AFP_CHANGEPW, UAM_AFPSERVER_PREAUTH, afp_changepw, NULL);
167     }
168     else {
169         afp_switch = postauth_switch;
170         switch (obj->afp_version) {
171
172         case 33:
173         case 32:
174 #ifdef HAVE_ACLS
175             uam_afpserver_action(AFP_GETACL, UAM_AFPSERVER_POSTAUTH, afp_getacl, NULL);
176             uam_afpserver_action(AFP_SETACL, UAM_AFPSERVER_POSTAUTH, afp_setacl, NULL);
177             uam_afpserver_action(AFP_ACCESS, UAM_AFPSERVER_POSTAUTH, afp_access, NULL);
178 #endif /* HAVE_ACLS */
179             uam_afpserver_action(AFP_GETEXTATTR, UAM_AFPSERVER_POSTAUTH, afp_getextattr, NULL);
180             uam_afpserver_action(AFP_SETEXTATTR, UAM_AFPSERVER_POSTAUTH, afp_setextattr, NULL);
181             uam_afpserver_action(AFP_REMOVEATTR, UAM_AFPSERVER_POSTAUTH, afp_remextattr, NULL);
182             uam_afpserver_action(AFP_LISTEXTATTR, UAM_AFPSERVER_POSTAUTH, afp_listextattr, NULL);
183
184         case 31:
185             uam_afpserver_action(AFP_SYNCDIR, UAM_AFPSERVER_POSTAUTH, afp_syncdir, NULL);
186             uam_afpserver_action(AFP_SYNCFORK, UAM_AFPSERVER_POSTAUTH, afp_syncfork, NULL);
187             uam_afpserver_action(AFP_SPOTLIGHT_PRIVATE, UAM_AFPSERVER_POSTAUTH, afp_null_nolog, NULL);
188             uam_afpserver_action(AFP_ENUMERATE_EXT2, UAM_AFPSERVER_POSTAUTH, afp_enumerate_ext2, NULL);
189
190         case 30:
191             uam_afpserver_action(AFP_ENUMERATE_EXT, UAM_AFPSERVER_POSTAUTH, afp_enumerate_ext, NULL);
192             uam_afpserver_action(AFP_BYTELOCK_EXT,  UAM_AFPSERVER_POSTAUTH, afp_bytelock_ext, NULL);
193             /* catsearch_ext uses the same packet as catsearch FIXME double check this, it wasn't true for enue
194                enumerate_ext */
195             uam_afpserver_action(AFP_CATSEARCH_EXT, UAM_AFPSERVER_POSTAUTH, afp_catsearch_ext, NULL);
196             uam_afpserver_action(AFP_GETSESSTOKEN,  UAM_AFPSERVER_POSTAUTH, afp_getsession, NULL);
197             uam_afpserver_action(AFP_READ_EXT,      UAM_AFPSERVER_POSTAUTH, afp_read_ext, NULL);
198             uam_afpserver_action(AFP_WRITE_EXT,     UAM_AFPSERVER_POSTAUTH, afp_write_ext, NULL);
199             uam_afpserver_action(AFP_DISCTOLDSESS,  UAM_AFPSERVER_POSTAUTH, afp_disconnect, NULL);
200
201         case 22:
202             /*
203              * If first connection to a server is done in classic AFP2.2 version is used
204              * but OSX uses AFP3.x FPzzz command !
205              */
206             uam_afpserver_action(AFP_ZZZ,  UAM_AFPSERVER_POSTAUTH, afp_zzz, NULL);
207             break;
208         }
209     }
210
211     return AFP_OK;
212 }
213
214 static int login(AFPObj *obj, struct passwd *pwd, void (*logout)(void), int expired)
215 {
216 #ifdef ADMIN_GRP
217     int admin = 0;
218 #endif /* ADMIN_GRP */
219
220     if ( pwd->pw_uid == 0 ) {   /* don't allow root login */
221         LOG(log_error, logtype_afpd, "login: root login denied!" );
222         return AFPERR_NOTAUTH;
223     }
224
225     LOG(log_note, logtype_afpd, "%s Login by %s",
226         afp_versions[afp_version_index].av_name, pwd->pw_name);
227
228     if (set_groups(obj, pwd) != 0)
229         return AFPERR_BADUAM;
230
231 #ifdef ADMIN_GRP
232     LOG(log_debug, logtype_afpd, "obj->options.admingid == %d", obj->options.admingid);
233
234     if (obj->options.admingid != 0) {
235         int i;
236         for (i = 0; i < obj->ngroups; i++) {
237             if (obj->groups[i] == obj->options.admingid) admin = 1;
238         }
239     }
240     if (admin) {
241         ad_setfuid(0);
242         LOG(log_info, logtype_afpd, "admin login -- %s", pwd->pw_name );
243     }
244     if (!admin)
245 #endif /* ADMIN_GRP */
246 #ifdef TRU64
247     {
248         struct DSI *dsi = obj->handle;
249         struct hostent *hp;
250         char *clientname;
251         int argc;
252         char **argv;
253         char hostname[256];
254
255         afp_get_cmdline( &argc, &argv );
256
257         hp = gethostbyaddr( (char *) &dsi->client.sin_addr,
258                             sizeof( struct in_addr ),
259                             dsi->client.sin_family );
260
261         if( hp )
262             clientname = hp->h_name;
263         else
264             clientname = inet_ntoa( dsi->client.sin_addr );
265
266         sprintf( hostname, "%s@%s", pwd->pw_name, clientname );
267
268         if( sia_become_user( NULL, argc, argv, hostname, pwd->pw_name,
269                              NULL, FALSE, NULL, NULL,
270                              SIA_BEU_REALLOGIN ) != SIASUCCESS )
271             return AFPERR_BADUAM;
272
273         LOG(log_info, logtype_afpd, "session from %s (%s)", hostname,
274             inet_ntoa( dsi->client.sin_addr ) );
275
276         if (setegid( pwd->pw_gid ) < 0 || seteuid( pwd->pw_uid ) < 0) {
277             LOG(log_error, logtype_afpd, "login: %s %s", pwd->pw_name, strerror(errno) );
278             return AFPERR_BADUAM;
279         }
280     }
281 #else /* TRU64 */
282     if (setegid( pwd->pw_gid ) < 0 || seteuid( pwd->pw_uid ) < 0) {
283         LOG(log_error, logtype_afpd, "login: %s %s", pwd->pw_name, strerror(errno) );
284         return AFPERR_BADUAM;
285     }
286 #endif /* TRU64 */
287
288     LOG(log_debug, logtype_afpd, "login: supplementary groups: %s", print_groups(obj->ngroups, obj->groups));
289
290     /* There's probably a better way to do this, but for now, we just play root */
291 #ifdef ADMIN_GRP
292     if (admin)
293         obj->uid = 0;
294     else
295 #endif /* ADMIN_GRP */
296         obj->uid = geteuid();
297
298     set_auth_switch(obj, expired);
299     /* save our euid, we need it for preexec_close */
300     obj->uid = geteuid();
301     obj->logout = logout;
302
303     /* pam_umask or similar might have changed our umask */
304     (void)umask(obj->options.umask);
305
306     /* Some PAM module might have reset our signal handlers and timer, so we need to reestablish them */
307     afp_over_dsi_sighandlers(obj);
308
309     return( AFP_OK );
310 }
311
312 /* ---------------------- */
313 int afp_zzz(AFPObj *obj, char *ibuf, size_t ibuflen, char *rbuf, size_t *rbuflen)
314 {
315     uint32_t data;
316     DSI *dsi = (DSI *)AFPobj->dsi;
317
318     *rbuflen = 0;
319     ibuf += 2;
320     ibuflen -= 2;
321
322     if (ibuflen < 4)
323         return AFPERR_MISC;
324     memcpy(&data, ibuf, 4); /* flag */
325     data = ntohl(data);
326
327     /*
328      * Possible sleeping states:
329      * 1) normal sleep: DSI_SLEEPING (up to 10.3)
330      * 2) extended sleep: DSI_SLEEPING | DSI_EXTSLEEP (starting with 10.4)
331      */
332
333     if (data & AFPZZZ_EXT_WAKEUP) {
334         /* wakeup request from exetended sleep */
335         if (dsi->flags & DSI_EXTSLEEP) {
336             LOG(log_note, logtype_afpd, "afp_zzz: waking up from extended sleep");
337             dsi->flags &= ~(DSI_SLEEPING | DSI_EXTSLEEP);
338             ipc_child_state(obj, DSI_RUNNING);
339         }
340     } else {
341         /* sleep request */
342         dsi->flags |= DSI_SLEEPING;
343         if (data & AFPZZZ_EXT_SLEEP) {
344             LOG(log_note, logtype_afpd, "afp_zzz: entering extended sleep");
345             dsi->flags |= DSI_EXTSLEEP;
346             ipc_child_state(obj, DSI_EXTSLEEP);
347         } else {
348             LOG(log_note, logtype_afpd, "afp_zzz: entering normal sleep");
349             ipc_child_state(obj, DSI_SLEEPING);
350         }
351     }
352
353     /*
354      * According to AFP 3.3 spec we should not return anything,
355      * but eg 10.5.8 server still returns the numbers of hours
356      * the server is keeping the sessino (ie max sleeptime).
357      */
358     data = obj->options.sleep / 120; /* hours */
359     if (!data) {
360         data = 1;
361     }
362     *rbuflen = sizeof(data);
363     data = htonl(data);
364     memcpy(rbuf, &data, sizeof(data));
365     rbuf += sizeof(data);
366
367     return AFP_OK;
368 }
369
370 /* ---------------------- */
371 static int create_session_token(AFPObj *obj)
372 {
373     pid_t pid;
374
375     /* use 8 bytes for token as OSX, don't know if it helps */
376     if ( sizeof(pid_t) > SESSIONTOKEN_LEN) {
377         LOG(log_error, logtype_afpd, "sizeof(pid_t) > %u", SESSIONTOKEN_LEN );
378         return AFPERR_MISC;
379     }
380
381     if ( NULL == (obj->sinfo.sessiontoken = malloc(SESSIONTOKEN_LEN)) )
382         return AFPERR_MISC;
383
384     memset(obj->sinfo.sessiontoken, 0, SESSIONTOKEN_LEN);
385     obj->sinfo.sessiontoken_len = SESSIONTOKEN_LEN;
386     pid = getpid();
387     memcpy(obj->sinfo.sessiontoken, &pid, sizeof(pid_t));
388
389     return 0;
390 }
391
392 static int create_session_key(AFPObj *obj)
393 {
394     /* create session key */
395     if (obj->sinfo.sessionkey == NULL) {
396         if (NULL == (obj->sinfo.sessionkey = malloc(SESSIONKEY_LEN)) )
397             return AFPERR_MISC;
398         uam_random_string(obj, obj->sinfo.sessionkey, SESSIONKEY_LEN);
399         obj->sinfo.sessionkey_len = SESSIONKEY_LEN;
400     }
401     return AFP_OK;
402 }
403
404
405 /* ---------------------- */
406 int afp_getsession(
407     AFPObj *obj,
408     char   *ibuf, size_t ibuflen, 
409     char   *rbuf, size_t *rbuflen)
410 {
411     uint16_t           type;
412     uint32_t           idlen = 0;
413     uint32_t       boottime;
414     uint32_t           tklen, tp;
415     char                *token;
416     char                *p;
417
418     *rbuflen = 0;
419     tklen = 0;
420
421     if (ibuflen < 2 + sizeof(type)) {
422         return AFPERR_PARAM;
423     }
424
425     ibuf += 2;
426     ibuflen -= 2;
427
428     memcpy(&type, ibuf, sizeof(type));
429     type = ntohs(type);
430     ibuf += sizeof(type);
431     ibuflen -= sizeof(type);
432
433     if ( obj->sinfo.sessiontoken == NULL ) {
434         if ( create_session_token( obj ) )
435             return AFPERR_MISC;
436     }
437
438     /*
439      *
440      */
441     switch (type) {
442     case 0: /* old version ?*/
443         tklen = obj->sinfo.sessiontoken_len;
444         token = obj->sinfo.sessiontoken;
445         break;
446     case 1: /* disconnect */
447     case 2: /* reconnect update id */
448         if (ibuflen >= sizeof(idlen)) {
449             memcpy(&idlen, ibuf, sizeof(idlen));
450             idlen = ntohl(idlen);
451             ibuf += sizeof(idlen);
452             ibuflen -= sizeof(idlen);
453             if (ibuflen < idlen) {
454                 return AFPERR_PARAM;
455             }
456             /* memcpy (id, ibuf, idlen) */
457             tklen = obj->sinfo.sessiontoken_len;
458             token = obj->sinfo.sessiontoken;
459         }
460         break;
461     case 3:
462     case 4:
463         if (ibuflen >= 8 ) {
464             p = ibuf;
465             memcpy( &idlen, ibuf, sizeof(idlen));
466             idlen = ntohl(idlen);
467             ibuf += sizeof(idlen);
468             ibuflen -= sizeof(idlen);
469             ibuf += sizeof(boottime);
470             ibuflen -= sizeof(boottime);
471             if (ibuflen < idlen || idlen > (90-10)) {
472                 return AFPERR_PARAM;
473             }
474             if (!obj->sinfo.clientid) {
475                 obj->sinfo.clientid = malloc(idlen + 8);
476                 memcpy(obj->sinfo.clientid, p, idlen + 8);
477                 obj->sinfo.clientid_len = idlen + 8;
478             }
479             if (ipc_child_write(obj->ipc_fd, IPC_GETSESSION, idlen+8, p) != 0)
480                 return AFPERR_MISC;
481             tklen = obj->sinfo.sessiontoken_len;
482             token = obj->sinfo.sessiontoken;
483         }
484         break;
485     case 8: /* Panther Kerberos Token */
486         tklen = obj->sinfo.cryptedkey_len;
487         token = obj->sinfo.cryptedkey;
488         break;
489     default:
490         return AFPERR_NOOP;
491         break;
492
493     }
494
495     if (tklen == 0)
496         return AFPERR_MISC;
497
498     tp = htonl(tklen);
499     memcpy(rbuf, &tp, sizeof(tklen));
500     rbuf += sizeof(tklen);
501     *rbuflen += sizeof(tklen);
502
503     memcpy(rbuf, token, tklen);
504     *rbuflen += tklen;
505
506     return AFP_OK;
507 }
508
509 /* ---------------------- */
510 int afp_disconnect(AFPObj *obj, char *ibuf, size_t ibuflen _U_, char *rbuf _U_, size_t *rbuflen)
511 {
512     DSI                 *dsi = (DSI *)obj->dsi;
513     uint16_t           type;
514     uint32_t           tklen;
515     pid_t               token;
516     int                 i;
517
518     *rbuflen = 0;
519     ibuf += 2;
520
521 #if 0
522     /* check for guest user */
523     if ( 0 == (strcasecmp(obj->username, obj->options.guest)) ) {
524         return AFPERR_MISC;
525     }
526 #endif
527
528     memcpy(&type, ibuf, sizeof(type));
529     type = ntohs(type);
530     ibuf += sizeof(type);
531
532     memcpy(&tklen, ibuf, sizeof(tklen));
533     tklen = ntohl(tklen);
534     ibuf += sizeof(tklen);
535
536     if ( sizeof(pid_t) > SESSIONTOKEN_LEN) {
537         LOG(log_error, logtype_afpd, "sizeof(pid_t) > %u", SESSIONTOKEN_LEN );
538         return AFPERR_MISC;
539     }
540     if (tklen != SESSIONTOKEN_LEN) {
541         return AFPERR_MISC;
542     }
543     tklen = sizeof(pid_t);
544     memcpy(&token, ibuf, tklen);
545
546     /* our stuff is pid + zero pad */
547     ibuf += tklen;
548     for (i = tklen; i < SESSIONTOKEN_LEN; i++, ibuf++) {
549         if (*ibuf != 0) {
550             return AFPERR_MISC;
551         }
552     }
553
554     LOG(log_note, logtype_afpd, "afp_disconnect: trying primary reconnect");
555     dsi->flags |= DSI_RECONINPROG;
556
557     /* Deactivate tickle timer */
558     const struct itimerval none = {{0, 0}, {0, 0}};
559     setitimer(ITIMER_REAL, &none, NULL);
560
561     /* check for old session, possibly transfering session from here to there */
562     if (ipc_child_write(obj->ipc_fd, IPC_DISCOLDSESSION, tklen, &token) != 0)
563         goto exit;
564     /* write uint16_t DSI request ID */
565     if (writet(obj->ipc_fd, &dsi->header.dsi_requestID, 2, 0, 2) != 2) {
566         LOG(log_error, logtype_afpd, "afp_disconnect: couldn't send DSI request ID");
567         goto exit;
568     }
569     /* now send our connected AFP client socket */
570     if (send_fd(obj->ipc_fd, dsi->socket) != 0)
571         goto exit;
572     /* Now see what happens: either afpd master sends us SIGTERM because our session */
573     /* has been transfered to a old disconnected session, or we continue    */
574     sleep(5);
575
576     if (!(dsi->flags & DSI_RECONINPROG)) { /* deleted in SIGTERM handler */
577         /* Reconnect succeeded, we exit now after sleeping some more */
578         sleep(2); /* sleep some more to give the recon. session time */
579         LOG(log_note, logtype_afpd, "afp_disconnect: primary reconnect succeeded");
580         exit(0);
581     }
582
583 exit:
584     /* Reinstall tickle timer */
585     setitimer(ITIMER_REAL, &dsi->timer, NULL);
586
587     LOG(log_error, logtype_afpd, "afp_disconnect: primary reconnect failed");
588     return AFPERR_MISC;
589 }
590
591 /* ---------------------- */
592 static int get_version(AFPObj *obj, char *ibuf, size_t ibuflen, size_t len)
593 {
594     int num,i;
595
596     if (!len || len > ibuflen)
597         return AFPERR_BADVERS;
598
599     num = sizeof( afp_versions ) / sizeof( afp_versions[ 0 ]);
600     for ( i = 0; i < num; i++ ) {
601         if ( strncmp( ibuf, afp_versions[ i ].av_name , len ) == 0 ) {
602             obj->afp_version = afp_versions[ i ].av_number;
603             afp_version_index = i;
604             break;
605         }
606     }
607     if ( i == num )                 /* An inappropo version */
608         return AFPERR_BADVERS ;
609
610     /* FIXME Hack */
611     if (obj->afp_version >= 30 && sizeof(off_t) != 8) {
612         LOG(log_error, logtype_afpd, "get_version: no LARGE_FILE support recompile!" );
613         return AFPERR_BADVERS ;
614     }
615
616     return 0;
617 }
618
619 /* ---------------------- */
620 int afp_login(AFPObj *obj, char *ibuf, size_t ibuflen, char *rbuf, size_t *rbuflen)
621 {
622     struct passwd *pwd = NULL;
623     size_t len;
624     int     i;
625
626     *rbuflen = 0;
627
628     if ( nologin & 1)
629         return send_reply(obj, AFPERR_SHUTDOWN );
630
631     if (ibuflen < 2)
632         return send_reply(obj, AFPERR_BADVERS );
633
634     ibuf++;
635     len = (unsigned char) *ibuf++;
636     ibuflen -= 2;
637
638     i = get_version(obj, ibuf, ibuflen, len);
639     if (i)
640         return send_reply(obj, i );
641
642     if (ibuflen <= len)
643         return send_reply(obj, AFPERR_BADUAM);
644
645     ibuf += len;
646     ibuflen -= len;
647
648     len = (unsigned char) *ibuf++;
649     ibuflen--;
650
651     if (!len || len > ibuflen)
652         return send_reply(obj, AFPERR_BADUAM);
653
654     if (NULL == (afp_uam = auth_uamfind(UAM_SERVER_LOGIN, ibuf, len)) )
655         return send_reply(obj, AFPERR_BADUAM);
656     ibuf += len;
657     ibuflen -= len;
658
659     if (AFP_OK != (i = create_session_key(obj)) )
660         return send_reply(obj, i);
661
662     i = afp_uam->u.uam_login.login(obj, &pwd, ibuf, ibuflen, rbuf, rbuflen);
663
664     if (!pwd || ( i != AFP_OK && i != AFPERR_PWDEXPR))
665         return send_reply(obj, i);
666
667     return send_reply(obj, login(obj, pwd, afp_uam->u.uam_login.logout, ((i==AFPERR_PWDEXPR)?1:0)));
668 }
669
670 /* ---------------------- */
671 int afp_login_ext(AFPObj *obj, char *ibuf, size_t ibuflen, char *rbuf, size_t *rbuflen)
672 {
673     struct passwd *pwd = NULL;
674     size_t  len;
675     int     i;
676     char        type;
677     uint16_t   len16;
678     char        *username;
679
680     *rbuflen = 0;
681
682     if ( nologin & 1)
683         return send_reply(obj, AFPERR_SHUTDOWN );
684
685     if (ibuflen < 5)
686         return send_reply(obj, AFPERR_BADVERS );
687
688     ibuf++;
689     ibuf++;     /* pad  */
690     ibuf +=2;   /* flag */
691
692     len = (unsigned char) *ibuf;
693     ibuf++;
694     ibuflen -= 5;
695
696     i = get_version(obj, ibuf, ibuflen, len);
697     if (i)
698         return send_reply(obj, i );
699
700     if (ibuflen <= len)
701         return send_reply(obj, AFPERR_BADUAM);
702
703     ibuf    += len;
704     ibuflen -= len;
705
706     len = (unsigned char) *ibuf;
707     ibuf++;
708     ibuflen--;
709
710     if (!len || len > ibuflen)
711         return send_reply(obj, AFPERR_BADUAM);
712
713     if ((afp_uam = auth_uamfind(UAM_SERVER_LOGIN, ibuf, len)) == NULL)
714         return send_reply(obj, AFPERR_BADUAM);
715     ibuf    += len;
716     ibuflen -= len;
717
718     if (!afp_uam->u.uam_login.login_ext) {
719         LOG(log_error, logtype_afpd, "login_ext: uam %s not AFP 3 ready!", afp_uam->uam_name );
720         return send_reply(obj, AFPERR_BADUAM);
721     }
722     /* user name */
723     if (ibuflen <= 1 +sizeof(len16))
724         return send_reply(obj, AFPERR_PARAM);
725     type = *ibuf;
726     username = ibuf;
727     ibuf++;
728     ibuflen--;
729     if (type != 3)
730         return send_reply(obj, AFPERR_PARAM);
731
732     memcpy(&len16, ibuf, sizeof(len16));
733     ibuf += sizeof(len16);
734     ibuflen -= sizeof(len16);
735     len = ntohs(len16);
736     if (len > ibuflen)
737         return send_reply(obj, AFPERR_PARAM);
738     ibuf += len;
739     ibuflen -= len;
740
741     /* directory service name */
742     if (!ibuflen)
743         return send_reply(obj, AFPERR_PARAM);
744     type = *ibuf;
745     ibuf++;
746     ibuflen--;
747
748     switch(type) {
749     case 1:
750     case 2:
751         if (!ibuflen)
752             return send_reply(obj, AFPERR_PARAM);
753         len = (unsigned char) *ibuf;
754         ibuf++;
755         ibuflen--;
756         break;
757     case 3:
758         /* With "No User Authen" it is equal */
759         if (ibuflen < sizeof(len16))
760             return send_reply(obj, AFPERR_PARAM);
761         memcpy(&len16, ibuf, sizeof(len16));
762         ibuf += sizeof(len16);
763         ibuflen -= sizeof(len16);
764         len = ntohs(len16);
765         break;
766     default:
767         return send_reply(obj, AFPERR_PARAM);
768     }
769 #if 0
770     if (len != 0) {
771         LOG(log_error, logtype_afpd, "login_ext: directory service path not null!" );
772         return send_reply(obj, AFPERR_PARAM);
773     }
774 #endif
775     ibuf += len;
776     ibuflen -= len;
777
778     /* Pad */
779     if (ibuflen && ((unsigned long) ibuf & 1)) { /* pad character */
780         ibuf++;
781         ibuflen--;
782     }
783
784     if (AFP_OK != (i = create_session_key(obj)) ) {
785         return send_reply(obj, i);
786     }
787
788     /* FIXME user name are in UTF8 */
789     i = afp_uam->u.uam_login.login_ext(obj, username, &pwd, ibuf, ibuflen, rbuf, rbuflen);
790
791     if (!pwd || ( i != AFP_OK && i != AFPERR_PWDEXPR))
792         return send_reply(obj, i);
793
794     return send_reply(obj, login(obj, pwd, afp_uam->u.uam_login.logout, ((i==AFPERR_PWDEXPR)?1:0)));
795 }
796
797 /* ---------------------- */
798 int afp_logincont(AFPObj *obj, char *ibuf, size_t ibuflen, char *rbuf, size_t *rbuflen)
799 {
800     struct passwd *pwd = NULL;
801     int err;
802
803     if ( afp_uam == NULL || afp_uam->u.uam_login.logincont == NULL || ibuflen < 2 ) {
804         *rbuflen = 0;
805         return send_reply(obj, AFPERR_NOTAUTH );
806     }
807
808     ibuf += 2; ibuflen -= 2;
809     err = afp_uam->u.uam_login.logincont(obj, &pwd, ibuf, ibuflen,
810                                          rbuf, rbuflen);
811     if (!pwd || ( err != AFP_OK && err != AFPERR_PWDEXPR))
812         return send_reply(obj, err);
813
814     return send_reply(obj, login(obj, pwd, afp_uam->u.uam_login.logout, ((err==AFPERR_PWDEXPR)?1:0)));
815 }
816
817
818 int afp_logout(AFPObj *obj, char *ibuf _U_, size_t ibuflen  _U_, char *rbuf  _U_, size_t *rbuflen)
819 {
820     DSI *dsi = (DSI *)(obj->dsi);
821
822     LOG(log_note, logtype_afpd, "AFP logout by %s", obj->username);
823     of_close_all_forks(obj);
824     close_all_vol(obj);
825     dsi->flags = DSI_AFP_LOGGED_OUT;
826     *rbuflen = 0;
827     return AFP_OK;
828 }
829
830
831
832 /* change password  --
833  * NOTE: an FPLogin must already have completed successfully for this
834  *       to work. this also does a little pre-processing before it hands
835  *       it off to the uam.
836  */
837 int afp_changepw(AFPObj *obj, char *ibuf, size_t ibuflen, char *rbuf, size_t *rbuflen)
838 {
839     char username[MACFILELEN + 1], *start = ibuf;
840     struct uam_obj *uam;
841     struct passwd *pwd;
842     size_t len;
843     int    ret;
844
845     *rbuflen = 0;
846     ibuf += 2;
847
848     /* check if password change is allowed, OS-X ignores the flag.
849      * we shouldn't trust the client on this anyway.
850      * not sure about the "right" error code, NOOP for now */
851     if (!(obj->options.passwdbits & PASSWD_SET))
852         return AFPERR_NOOP;
853
854     /* make sure we can deal w/ this uam */
855     len = (unsigned char) *ibuf++;
856     if ((uam = auth_uamfind(UAM_SERVER_CHANGEPW, ibuf, len)) == NULL)
857         return AFPERR_BADUAM;
858
859     ibuf += len;
860     if ((len + 1) & 1) /* pad byte */
861         ibuf++;
862
863     if (obj->afp_version < 30) {
864         len = (unsigned char) *ibuf++;
865         if ( len > sizeof(username) - 1) {
866             return AFPERR_PARAM;
867         }
868         memcpy(username, ibuf, len);
869         username[ len ] = '\0';
870         ibuf += len;
871         if ((len + 1) & 1) /* pad byte */
872             ibuf++;
873     } else {
874         /* AFP > 3.0 doesn't pass the username, APF 3.1 specs page 124 */
875         if ( ibuf[0] != '\0' || ibuf[1] != '\0')
876             return AFPERR_PARAM;
877         ibuf += 2;
878         len = MIN(sizeof(username) - 1, strlen(obj->username));
879         memcpy(username, obj->username, len);
880         username[ len ] = '\0';
881     }
882
883
884     LOG(log_info, logtype_afpd, "changing password for <%s>", username);
885
886     if (( pwd = uam_getname( obj, username, sizeof(username))) == NULL )
887         return AFPERR_PARAM;
888
889     /* send it off to the uam. we really don't use ibuflen right now. */
890     if (ibuflen < (size_t)(ibuf - start)) 
891         return AFPERR_PARAM;
892     
893     ibuflen -= (ibuf - start);
894     ret = uam->u.uam_changepw(obj, username, pwd, ibuf, ibuflen,
895                               rbuf, rbuflen);
896     LOG(log_info, logtype_afpd, "password change %s.",
897         (ret == AFPERR_AUTHCONT) ? "continued" :
898         (ret ? "failed" : "succeeded"));
899     if ( ret == AFP_OK )
900         set_auth_switch(obj, 0);
901
902     return ret;
903 }
904
905
906 /* FPGetUserInfo */
907 int afp_getuserinfo(AFPObj *obj _U_, char *ibuf, size_t ibuflen _U_, char *rbuf, size_t *rbuflen)
908 {
909     uint8_t  thisuser;
910     uint32_t id;
911     uint16_t bitmap;
912     char *bitmapp;
913
914     LOG(log_debug, logtype_afpd, "begin afp_getuserinfo:");
915
916     *rbuflen = 0;
917     ibuf++;
918     thisuser = *ibuf++;
919     ibuf += sizeof(id); /* userid is not used in AFP 2.0 */
920     memcpy(&bitmap, ibuf, sizeof(bitmap));
921     bitmap = ntohs(bitmap);
922
923     /* deal with error cases. we don't have to worry about
924      * AFPERR_ACCESS or AFPERR_NOITEM as geteuid and getegid always
925      * succeed. */
926     if (!thisuser)
927         return AFPERR_PARAM;
928     if ((bitmap & USERIBIT_ALL) != bitmap)
929         return AFPERR_BITMAP;
930
931     /* remember place where we store the possibly modified bitmap later */
932     memcpy(rbuf, ibuf, sizeof(bitmap));
933     bitmapp = rbuf;
934     rbuf += sizeof(bitmap);
935     *rbuflen = sizeof(bitmap);
936
937     /* copy the user/group info */
938     if (bitmap & USERIBIT_USER) {
939         id = htonl(geteuid());
940         memcpy(rbuf, &id, sizeof(id));
941         rbuf += sizeof(id);
942         *rbuflen += sizeof(id);
943     }
944
945     if (bitmap & USERIBIT_GROUP) {
946         id = htonl(getegid());
947         memcpy(rbuf, &id, sizeof(id));
948         rbuf += sizeof(id);
949         *rbuflen += sizeof(id);
950     }
951
952     if (bitmap & USERIBIT_UUID) {
953         if ( ! (obj->options.flags & OPTION_UUID)) {
954             bitmap &= ~USERIBIT_UUID;
955             bitmap = htons(bitmap);
956             memcpy(bitmapp, &bitmap, sizeof(bitmap));
957         } else {
958             LOG(log_debug, logtype_afpd, "afp_getuserinfo: get UUID for \'%s\'", obj->username);
959             int ret;
960             atalk_uuid_t uuid;
961             ret = getuuidfromname( obj->username, UUID_USER, uuid);
962             if (ret != 0) {
963                 LOG(log_info, logtype_afpd, "afp_getuserinfo: error getting UUID!");
964                 return AFPERR_NOITEM;
965             }
966             LOG(log_debug, logtype_afpd, "afp_getuserinfo: got UUID: %s", uuid_bin2string(uuid));
967
968             memcpy(rbuf, uuid, UUID_BINSIZE);
969             rbuf += UUID_BINSIZE;
970             *rbuflen += UUID_BINSIZE;
971         }
972     }
973
974     LOG(log_debug, logtype_afpd, "END afp_getuserinfo:");
975     return AFP_OK;
976 }
977
978 #define UAM_LIST(type) (((type) == UAM_SERVER_LOGIN || (type) == UAM_SERVER_LOGIN_EXT) ? &uam_login : \
979                         (((type) == UAM_SERVER_CHANGEPW) ?              \
980                          &uam_changepw : NULL))
981
982 /* just do a linked list search. this could be sped up with a hashed
983  * list, but i doubt anyone's going to have enough uams to matter. */
984 struct uam_obj *auth_uamfind(const int type, const char *name,
985                              const int len)
986 {
987     struct uam_obj *prev, *start;
988
989     if (!name || !(start = UAM_LIST(type)))
990         return NULL;
991
992     prev = start;
993     while ((prev = prev->uam_prev) != start)
994         if (strndiacasecmp(prev->uam_name, name, len) == 0)
995             return prev;
996
997     return NULL;
998 }
999
1000 int auth_register(const int type, struct uam_obj *uam)
1001 {
1002     struct uam_obj *start;
1003
1004     if (!uam || !uam->uam_name || (*uam->uam_name == '\0'))
1005         return -1;
1006
1007     if (!(start = UAM_LIST(type)))
1008         return 1; /* we don't know what to do with it, caller must free it */
1009
1010     uam_attach(start, uam);
1011     return 0;
1012 }
1013
1014 /* load all of the modules */
1015 int auth_load(const char *path, const char *list)
1016 {
1017     char name[MAXPATHLEN + 1], buf[MAXPATHLEN + 1], *p;
1018     struct uam_mod *mod;
1019     struct stat st;
1020     size_t len;
1021
1022     if (!path || !*path || !list || (len = strlen(path)) > sizeof(name) - 2)
1023         return -1;
1024
1025     strlcpy(buf, list, sizeof(buf));
1026     if ((p = strtok(buf, ", ")) == NULL)
1027         return -1;
1028
1029     strcpy(name, path);
1030     if (name[len - 1] != '/') {
1031         strcat(name, "/");
1032         len++;
1033     }
1034
1035     while (p) {
1036         strlcpy(name + len, p, sizeof(name) - len);
1037         LOG(log_debug, logtype_afpd, "uam: loading (%s)", name);
1038         /*
1039           if ((stat(name, &st) == 0) && (mod = uam_load(name, p))) {
1040         */
1041         if (stat(name, &st) == 0) {
1042             if ((mod = uam_load(name, p))) {
1043                 uam_attach(&uam_modules, mod);
1044                 LOG(log_debug, logtype_afpd, "uam: %s loaded", p);
1045             } else {
1046                 LOG(log_error, logtype_afpd, "uam: %s load failure",p);
1047             }
1048         } else {
1049             LOG(log_info, logtype_afpd, "uam: uam not found (status=%d)", stat(name, &st));
1050         }
1051         p = strtok(NULL, ", ");
1052     }
1053
1054     return 0;
1055 }
1056
1057 /* get rid of all of the uams */
1058 void auth_unload(void)
1059 {
1060     struct uam_mod *mod, *prev, *start = &uam_modules;
1061
1062     prev = start->uam_prev;
1063     while ((mod = prev) != start) {
1064         prev = prev->uam_prev;
1065         uam_detach(mod);
1066         uam_unload(mod);
1067     }
1068 }