[BACK]Return to auth2.c CVS log [TXT][DIR] Up to [local] / src / usr.bin / ssh

Annotation of src/usr.bin/ssh/auth2.c, Revision 1.6

1.1       markus      1: /*
                      2:  * Copyright (c) 2000 Markus Friedl.  All rights reserved.
                      3:  *
                      4:  * Redistribution and use in source and binary forms, with or without
                      5:  * modification, are permitted provided that the following conditions
                      6:  * are met:
                      7:  * 1. Redistributions of source code must retain the above copyright
                      8:  *    notice, this list of conditions and the following disclaimer.
                      9:  * 2. Redistributions in binary form must reproduce the above copyright
                     10:  *    notice, this list of conditions and the following disclaimer in the
                     11:  *    documentation and/or other materials provided with the distribution.
                     12:  * 3. All advertising materials mentioning features or use of this software
                     13:  *    must display the following acknowledgement:
                     14:  *      This product includes software developed by Markus Friedl.
                     15:  * 4. The name of the author may not be used to endorse or promote products
                     16:  *    derived from this software without specific prior written permission.
                     17:  *
                     18:  * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR
                     19:  * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
                     20:  * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.
                     21:  * IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT,
                     22:  * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT
                     23:  * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
                     24:  * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
                     25:  * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
                     26:  * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF
                     27:  * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
                     28:  */
                     29: #include "includes.h"
1.6     ! markus     30: RCSID("$OpenBSD: auth2.c,v 1.5 2000/05/01 23:13:39 djm Exp $");
1.1       markus     31:
                     32: #include <openssl/dsa.h>
                     33: #include <openssl/rsa.h>
                     34: #include <openssl/evp.h>
                     35:
                     36: #include "xmalloc.h"
                     37: #include "rsa.h"
                     38: #include "ssh.h"
                     39: #include "pty.h"
                     40: #include "packet.h"
                     41: #include "buffer.h"
                     42: #include "cipher.h"
                     43: #include "servconf.h"
                     44: #include "compat.h"
                     45: #include "channels.h"
                     46: #include "bufaux.h"
                     47: #include "ssh2.h"
                     48: #include "auth.h"
                     49: #include "session.h"
                     50: #include "dispatch.h"
                     51: #include "auth.h"
                     52: #include "key.h"
                     53: #include "kex.h"
                     54:
                     55: #include "dsa.h"
                     56: #include "uidswap.h"
                     57:
                     58: /* import */
                     59: extern ServerOptions options;
                     60: extern unsigned char *session_id2;
                     61: extern int session_id2_len;
                     62:
                     63: /* protocol */
                     64:
                     65: void   input_service_request(int type, int plen);
                     66: void   input_userauth_request(int type, int plen);
                     67: void   protocol_error(int type, int plen);
                     68:
                     69: /* auth */
                     70: int    ssh2_auth_none(struct passwd *pw);
                     71: int    ssh2_auth_password(struct passwd *pw);
                     72: int    ssh2_auth_pubkey(struct passwd *pw, unsigned char *raw, unsigned int rlen);
                     73:
                     74: /* helper */
                     75: struct passwd*  auth_set_user(char *u, char *s);
                     76: int    user_dsa_key_allowed(struct passwd *pw, Key *key);
                     77:
                     78: typedef struct Authctxt Authctxt;
                     79: struct Authctxt {
                     80:        char *user;
                     81:        char *service;
                     82:        struct passwd pw;
                     83:        int valid;
                     84: };
                     85: static Authctxt        *authctxt = NULL;
                     86: static int userauth_success = 0;
                     87:
                     88: /*
                     89:  * loop until userauth_success == TRUE
                     90:  */
                     91:
                     92: void
                     93: do_authentication2()
                     94: {
1.4       markus     95:        /* turn off skey/kerberos, not supported by SSH2 */
1.5       djm        96: #ifdef SKEY
1.4       markus     97:        options.skey_authentication = 0;
1.5       djm        98: #endif
                     99: #ifdef KRB4
1.4       markus    100:        options.kerberos_authentication = 0;
1.5       djm       101: #endif
1.4       markus    102:
1.1       markus    103:        dispatch_init(&protocol_error);
                    104:        dispatch_set(SSH2_MSG_SERVICE_REQUEST, &input_service_request);
                    105:        dispatch_run(DISPATCH_BLOCK, &userauth_success);
                    106:        do_authenticated2();
                    107: }
                    108:
                    109: void
                    110: protocol_error(int type, int plen)
                    111: {
                    112:        log("auth: protocol error: type %d plen %d", type, plen);
                    113:        packet_start(SSH2_MSG_UNIMPLEMENTED);
                    114:        packet_put_int(0);
                    115:        packet_send();
                    116:        packet_write_wait();
                    117: }
                    118:
                    119: void
                    120: input_service_request(int type, int plen)
                    121: {
                    122:        unsigned int len;
                    123:        int accept = 0;
                    124:        char *service = packet_get_string(&len);
                    125:        packet_done();
                    126:
                    127:        if (strcmp(service, "ssh-userauth") == 0) {
                    128:                if (!userauth_success) {
                    129:                        accept = 1;
                    130:                        /* now we can handle user-auth requests */
                    131:                        dispatch_set(SSH2_MSG_USERAUTH_REQUEST, &input_userauth_request);
                    132:                }
                    133:        }
                    134:        /* XXX all other service requests are denied */
                    135:
                    136:        if (accept) {
                    137:                packet_start(SSH2_MSG_SERVICE_ACCEPT);
                    138:                packet_put_cstring(service);
                    139:                packet_send();
                    140:                packet_write_wait();
                    141:        } else {
                    142:                debug("bad service request %s", service);
                    143:                packet_disconnect("bad service request %s", service);
                    144:        }
                    145:        xfree(service);
                    146: }
                    147:
                    148: void
                    149: input_userauth_request(int type, int plen)
                    150: {
1.3       markus    151:        static void (*authlog) (const char *fmt,...) = verbose;
                    152:        static int attempt = 0;
1.1       markus    153:        unsigned int len, rlen;
                    154:        int authenticated = 0;
1.3       markus    155:        char *raw, *user, *service, *method, *authmsg = NULL;
1.1       markus    156:        struct passwd *pw;
                    157:
1.3       markus    158:        if (++attempt == AUTH_FAIL_MAX)
1.1       markus    159:                packet_disconnect("too many failed userauth_requests");
                    160:
                    161:        raw = packet_get_raw(&rlen);
                    162:        if (plen != rlen)
                    163:                fatal("plen != rlen");
                    164:        user = packet_get_string(&len);
                    165:        service = packet_get_string(&len);
                    166:        method = packet_get_string(&len);
                    167:        debug("userauth-request for user %s service %s method %s", user, service, method);
                    168:
                    169:        /* XXX we only allow the ssh-connection service */
                    170:        pw = auth_set_user(user, service);
                    171:        if (pw && strcmp(service, "ssh-connection")==0) {
                    172:                if (strcmp(method, "none") == 0) {
                    173:                        authenticated = ssh2_auth_none(pw);
                    174:                } else if (strcmp(method, "password") == 0) {
                    175:                        authenticated = ssh2_auth_password(pw);
                    176:                } else if (strcmp(method, "publickey") == 0) {
                    177:                        authenticated = ssh2_auth_pubkey(pw, raw, rlen);
                    178:                }
                    179:        }
1.3       markus    180:        if (authenticated && pw && pw->pw_uid == 0 && !options.permit_root_login) {
                    181:                authenticated = 0;
                    182:                log("ROOT LOGIN REFUSED FROM %.200s",
                    183:                    get_canonical_hostname());
                    184:        }
                    185:
1.6     ! markus    186:        /* Raise logging level */
        !           187:        if (authenticated == 1 ||
        !           188:            attempt == AUTH_FAIL_LOG ||
        !           189:            strcmp(method, "password") == 0)
        !           190:                authlog = log;
        !           191:
        !           192:        /* Log before sending the reply */
        !           193:        if (authenticated == 1) {
        !           194:                authmsg = "Accepted";
        !           195:        } else if (authenticated == 0) {
        !           196:                authmsg = "Failed";
        !           197:        } else {
        !           198:                authmsg = "Postponed";
        !           199:        }
        !           200:        authlog("%s %s for %.200s from %.200s port %d ssh2",
        !           201:                authmsg,
        !           202:                method,
        !           203:                pw && pw->pw_uid == 0 ? "ROOT" : user,
        !           204:                get_remote_ipaddr(),
        !           205:                get_remote_port());
        !           206:
1.3       markus    207:        /* XXX todo: check if multiple auth methods are needed */
1.1       markus    208:        if (authenticated == 1) {
                    209:                /* turn off userauth */
                    210:                dispatch_set(SSH2_MSG_USERAUTH_REQUEST, &protocol_error);
                    211:                packet_start(SSH2_MSG_USERAUTH_SUCCESS);
                    212:                packet_send();
                    213:                packet_write_wait();
                    214:                /* now we can break out */
                    215:                userauth_success = 1;
                    216:        } else if (authenticated == 0) {
                    217:                packet_start(SSH2_MSG_USERAUTH_FAILURE);
                    218:                packet_put_cstring("publickey,password");       /* XXX dynamic */
                    219:                packet_put_char(0);                             /* XXX partial success, unused */
                    220:                packet_send();
                    221:                packet_write_wait();
                    222:        }
1.3       markus    223:
1.1       markus    224:        xfree(service);
                    225:        xfree(user);
                    226:        xfree(method);
                    227: }
                    228:
                    229: int
                    230: ssh2_auth_none(struct passwd *pw)
                    231: {
                    232:        packet_done();
                    233:        return auth_password(pw, "");
                    234: }
                    235: int
                    236: ssh2_auth_password(struct passwd *pw)
                    237: {
                    238:        char *password;
                    239:        int authenticated = 0;
                    240:        int change;
                    241:        unsigned int len;
                    242:        change = packet_get_char();
                    243:        if (change)
                    244:                log("password change not supported");
                    245:        password = packet_get_string(&len);
                    246:        packet_done();
1.3       markus    247:        if (options.password_authentication &&
                    248:            auth_password(pw, password) == 1)
1.1       markus    249:                authenticated = 1;
                    250:        memset(password, 0, len);
                    251:        xfree(password);
                    252:        return authenticated;
                    253: }
                    254: int
                    255: ssh2_auth_pubkey(struct passwd *pw, unsigned char *raw, unsigned int rlen)
                    256: {
                    257:        Buffer b;
                    258:        Key *key;
                    259:        char *pkalg, *pkblob, *sig;
                    260:        unsigned int alen, blen, slen;
                    261:        int have_sig;
                    262:        int authenticated = 0;
                    263:
1.3       markus    264:        if (options.rsa_authentication == 0) {
                    265:                debug("pubkey auth disabled");
                    266:                return 0;
                    267:        }
1.1       markus    268:        have_sig = packet_get_char();
                    269:        pkalg = packet_get_string(&alen);
                    270:        if (strcmp(pkalg, KEX_DSS) != 0) {
                    271:                xfree(pkalg);
                    272:                log("bad pkalg %s", pkalg);     /*XXX*/
                    273:                return 0;
                    274:        }
                    275:        pkblob = packet_get_string(&blen);
                    276:        key = dsa_key_from_blob(pkblob, blen);
1.2       markus    277:        if (key != NULL) {
                    278:                if (have_sig) {
                    279:                        sig = packet_get_string(&slen);
                    280:                        packet_done();
                    281:                        buffer_init(&b);
                    282:                        buffer_append(&b, session_id2, session_id2_len);
                    283:                        buffer_put_char(&b, SSH2_MSG_USERAUTH_REQUEST);
                    284:                        if (slen + 4 > rlen)
                    285:                                fatal("bad rlen/slen");
                    286:                        buffer_append(&b, raw, rlen - slen - 4);
1.1       markus    287: #ifdef DEBUG_DSS
1.2       markus    288:                        buffer_dump(&b);
1.1       markus    289: #endif
1.2       markus    290:                        /* test for correct signature */
                    291:                        if (user_dsa_key_allowed(pw, key) &&
                    292:                            dsa_verify(key, sig, slen, buffer_ptr(&b), buffer_len(&b)) == 1)
                    293:                                authenticated = 1;
                    294:                        buffer_clear(&b);
                    295:                        xfree(sig);
                    296:                } else {
                    297:                        packet_done();
                    298:                        debug("test key...");
                    299:                        /* test whether pkalg/pkblob are acceptable */
                    300:                        /* XXX fake reply and always send PK_OK ? */
1.6     ! markus    301:                        /*
        !           302:                         * XXX this allows testing whether a user is allowed
        !           303:                         * to login: if you happen to have a valid pubkey this
        !           304:                         * message is sent. the message is NEVER sent at all
        !           305:                         * if a user is not allowed to login. is this an
        !           306:                         * issue? -markus
        !           307:                         */
1.2       markus    308:                        if (user_dsa_key_allowed(pw, key)) {
                    309:                                packet_start(SSH2_MSG_USERAUTH_PK_OK);
                    310:                                packet_put_string(pkalg, alen);
                    311:                                packet_put_string(pkblob, blen);
                    312:                                packet_send();
                    313:                                packet_write_wait();
                    314:                                authenticated = -1;
                    315:                        }
1.1       markus    316:                }
1.2       markus    317:                key_free(key);
1.1       markus    318:        }
                    319:        xfree(pkalg);
                    320:        xfree(pkblob);
                    321:        return authenticated;
                    322: }
                    323:
                    324: /* set and get current user */
                    325:
                    326: struct passwd*
                    327: auth_get_user(void)
                    328: {
                    329:        return (authctxt != NULL && authctxt->valid) ? &authctxt->pw : NULL;
                    330: }
                    331:
                    332: struct passwd*
                    333: auth_set_user(char *u, char *s)
                    334: {
                    335:        struct passwd *pw, *copy;
                    336:
                    337:        if (authctxt == NULL) {
                    338:                authctxt = xmalloc(sizeof(*authctxt));
                    339:                authctxt->valid = 0;
                    340:                authctxt->user = xstrdup(u);
                    341:                authctxt->service = xstrdup(s);
                    342:                setproctitle("%s", u);
                    343:                pw = getpwnam(u);
                    344:                if (!pw || !allowed_user(pw)) {
1.3       markus    345:                        log("auth_set_user: illegal user %s", u);
1.1       markus    346:                        return NULL;
                    347:                }
                    348:                copy = &authctxt->pw;
                    349:                memset(copy, 0, sizeof(*copy));
                    350:                copy->pw_name = xstrdup(pw->pw_name);
                    351:                copy->pw_passwd = xstrdup(pw->pw_passwd);
                    352:                copy->pw_uid = pw->pw_uid;
                    353:                copy->pw_gid = pw->pw_gid;
                    354:                copy->pw_dir = xstrdup(pw->pw_dir);
                    355:                copy->pw_shell = xstrdup(pw->pw_shell);
                    356:                authctxt->valid = 1;
                    357:        } else {
                    358:                if (strcmp(u, authctxt->user) != 0 ||
                    359:                    strcmp(s, authctxt->service) != 0) {
                    360:                        log("auth_set_user: missmatch: (%s,%s)!=(%s,%s)",
                    361:                            u, s, authctxt->user, authctxt->service);
                    362:                        return NULL;
                    363:                }
                    364:        }
                    365:        return auth_get_user();
                    366: }
                    367:
                    368: /* return 1 if user allows given key */
                    369: int
                    370: user_dsa_key_allowed(struct passwd *pw, Key *key)
                    371: {
                    372:        char line[8192], file[1024];
                    373:        int found_key = 0;
                    374:        unsigned int bits = -1;
                    375:        FILE *f;
                    376:        unsigned long linenum = 0;
                    377:        struct stat st;
                    378:        Key *found;
                    379:
                    380:        /* Temporarily use the user's uid. */
                    381:        temporarily_use_uid(pw->pw_uid);
                    382:
                    383:        /* The authorized keys. */
                    384:        snprintf(file, sizeof file, "%.500s/%.100s", pw->pw_dir,
                    385:            SSH_USER_PERMITTED_KEYS2);
                    386:
                    387:        /* Fail quietly if file does not exist */
                    388:        if (stat(file, &st) < 0) {
                    389:                /* Restore the privileged uid. */
                    390:                restore_uid();
                    391:                return 0;
                    392:        }
                    393:        /* Open the file containing the authorized keys. */
                    394:        f = fopen(file, "r");
                    395:        if (!f) {
                    396:                /* Restore the privileged uid. */
                    397:                restore_uid();
                    398:                return 0;
                    399:        }
                    400:        if (options.strict_modes) {
                    401:                int fail = 0;
                    402:                char buf[1024];
                    403:                /* Check open file in order to avoid open/stat races */
                    404:                if (fstat(fileno(f), &st) < 0 ||
                    405:                    (st.st_uid != 0 && st.st_uid != pw->pw_uid) ||
                    406:                    (st.st_mode & 022) != 0) {
                    407:                        snprintf(buf, sizeof buf, "DSA authentication refused for %.100s: "
                    408:                            "bad ownership or modes for '%s'.", pw->pw_name, file);
                    409:                        fail = 1;
                    410:                } else {
                    411:                        /* Check path to SSH_USER_PERMITTED_KEYS */
                    412:                        int i;
                    413:                        static const char *check[] = {
                    414:                                "", SSH_USER_DIR, NULL
                    415:                        };
                    416:                        for (i = 0; check[i]; i++) {
                    417:                                snprintf(line, sizeof line, "%.500s/%.100s",
                    418:                                    pw->pw_dir, check[i]);
                    419:                                if (stat(line, &st) < 0 ||
                    420:                                    (st.st_uid != 0 && st.st_uid != pw->pw_uid) ||
                    421:                                    (st.st_mode & 022) != 0) {
                    422:                                        snprintf(buf, sizeof buf,
                    423:                                            "DSA authentication refused for %.100s: "
                    424:                                            "bad ownership or modes for '%s'.",
                    425:                                            pw->pw_name, line);
                    426:                                        fail = 1;
                    427:                                        break;
                    428:                                }
                    429:                        }
                    430:                }
                    431:                if (fail) {
                    432:                        log(buf);
                    433:                        fclose(f);
                    434:                        restore_uid();
                    435:                        return 0;
                    436:                }
                    437:        }
                    438:        found_key = 0;
                    439:        found = key_new(KEY_DSA);
                    440:
                    441:        while (fgets(line, sizeof(line), f)) {
                    442:                char *cp;
                    443:                linenum++;
                    444:                /* Skip leading whitespace, empty and comment lines. */
                    445:                for (cp = line; *cp == ' ' || *cp == '\t'; cp++)
                    446:                        ;
                    447:                if (!*cp || *cp == '\n' || *cp == '#')
                    448:                        continue;
                    449:                bits = key_read(found, &cp);
                    450:                if (bits == 0)
                    451:                        continue;
                    452:                if (key_equal(found, key)) {
                    453:                        found_key = 1;
                    454:                        debug("matching key found: file %s, line %ld",
                    455:                            file, linenum);
                    456:                        break;
                    457:                }
                    458:        }
                    459:        restore_uid();
                    460:        fclose(f);
                    461:        key_free(found);
                    462:        return found_key;
                    463: }