mirror of
https://github.com/unknownworlds/NS.git
synced 2024-12-01 00:32:06 +00:00
19b458f8bc
git-svn-id: https://unknownworlds.svn.cloudforge.com/ns1@141 67975925-1194-0748-b3d5-c16f83f1a3a1
1055 lines
30 KiB
C
1055 lines
30 KiB
C
/***************************************************************************
|
|
* _ _ ____ _
|
|
* Project ___| | | | _ \| |
|
|
* / __| | | | |_) | |
|
|
* | (__| |_| | _ <| |___
|
|
* \___|\___/|_| \_\_____|
|
|
*
|
|
* Copyright (C) 1998 - 2003, Daniel Stenberg, <daniel@haxx.se>, et al.
|
|
*
|
|
* This software is licensed as described in the file COPYING, which
|
|
* you should have received as part of this distribution. The terms
|
|
* are also available at http://curl.haxx.se/docs/copyright.html.
|
|
*
|
|
* You may opt to use, copy, modify, merge, publish, distribute and/or sell
|
|
* copies of the Software, and permit persons to whom the Software is
|
|
* furnished to do so, under the terms of the COPYING file.
|
|
*
|
|
* This software is distributed on an "AS IS" basis, WITHOUT WARRANTY OF ANY
|
|
* KIND, either express or implied.
|
|
*
|
|
* $Id: ssluse.c,v 1.72 2003/05/01 13:37:36 bagder Exp $
|
|
***************************************************************************/
|
|
|
|
/*
|
|
* The original SSL code for curl was written by
|
|
* Linas Vepstas <linas@linas.org> and Sampo Kellomaki <sampo@iki.fi>
|
|
*/
|
|
|
|
#include "setup.h"
|
|
|
|
#include <string.h>
|
|
#include <stdlib.h>
|
|
#ifdef HAVE_SYS_TYPES_H
|
|
#include <sys/types.h>
|
|
#endif
|
|
#ifdef HAVE_SYS_SOCKET_H
|
|
#include <sys/socket.h>
|
|
#endif
|
|
|
|
#include "urldata.h"
|
|
#include "sendf.h"
|
|
#include "formdata.h" /* for the boundary function */
|
|
#include "url.h" /* for the ssl config check function */
|
|
|
|
#ifdef USE_SSLEAY
|
|
#include <openssl/rand.h>
|
|
|
|
/* The last #include file should be: */
|
|
#ifdef MALLOCDEBUG
|
|
#include "memdebug.h"
|
|
#endif
|
|
|
|
#if OPENSSL_VERSION_NUMBER >= 0x0090581fL
|
|
#define HAVE_SSL_GET1_SESSION 1
|
|
#else
|
|
#undef HAVE_SSL_GET1_SESSION
|
|
#endif
|
|
|
|
#if OPENSSL_VERSION_NUMBER >= 0x00904100L
|
|
#define HAVE_USERDATA_IN_PWD_CALLBACK 1
|
|
#else
|
|
#undef HAVE_USERDATA_IN_PWD_CALLBACK
|
|
#endif
|
|
|
|
#if OPENSSL_VERSION_NUMBER >= 0x00907001L
|
|
/* ENGINE_load_private_key() takes four arguments */
|
|
#define HAVE_ENGINE_LOAD_FOUR_ARGS
|
|
#else
|
|
/* ENGINE_load_private_key() takes three arguments */
|
|
#undef HAVE_ENGINE_LOAD_FOUR_ARGS
|
|
#endif
|
|
|
|
|
|
#ifndef HAVE_USERDATA_IN_PWD_CALLBACK
|
|
static char global_passwd[64];
|
|
#endif
|
|
|
|
static int passwd_callback(char *buf, int num, int verify
|
|
#if HAVE_USERDATA_IN_PWD_CALLBACK
|
|
/* This was introduced in 0.9.4, we can set this
|
|
using SSL_CTX_set_default_passwd_cb_userdata()
|
|
*/
|
|
, void *global_passwd
|
|
#endif
|
|
)
|
|
{
|
|
if(verify)
|
|
fprintf(stderr, "%s\n", buf);
|
|
else {
|
|
if(num > (int)strlen((char *)global_passwd)) {
|
|
strcpy(buf, global_passwd);
|
|
return strlen(buf);
|
|
}
|
|
}
|
|
return 0;
|
|
}
|
|
|
|
static
|
|
bool seed_enough(int nread)
|
|
{
|
|
#ifdef HAVE_RAND_STATUS
|
|
nread = 0; /* to prevent compiler warnings */
|
|
|
|
/* only available in OpenSSL 0.9.5a and later */
|
|
if(RAND_status())
|
|
return TRUE;
|
|
#else
|
|
if(nread > 500)
|
|
/* this is a very silly decision to make */
|
|
return TRUE;
|
|
#endif
|
|
return FALSE; /* not enough */
|
|
}
|
|
|
|
static
|
|
int random_the_seed(struct SessionHandle *data)
|
|
{
|
|
char *buf = data->state.buffer; /* point to the big buffer */
|
|
int nread=0;
|
|
|
|
/* Q: should we add support for a random file name as a libcurl option?
|
|
A: Yes, it is here */
|
|
|
|
#ifndef RANDOM_FILE
|
|
/* if RANDOM_FILE isn't defined, we only perform this if an option tells
|
|
us to! */
|
|
if(data->set.ssl.random_file)
|
|
#define RANDOM_FILE "" /* doesn't matter won't be used */
|
|
#endif
|
|
{
|
|
/* let the option override the define */
|
|
nread += RAND_load_file((data->set.ssl.random_file?
|
|
data->set.ssl.random_file:RANDOM_FILE),
|
|
16384);
|
|
if(seed_enough(nread))
|
|
return nread;
|
|
}
|
|
|
|
#if defined(HAVE_RAND_EGD)
|
|
/* only available in OpenSSL 0.9.5 and later */
|
|
/* EGD_SOCKET is set at configure time or not at all */
|
|
#ifndef EGD_SOCKET
|
|
/* If we don't have the define set, we only do this if the egd-option
|
|
is set */
|
|
if(data->set.ssl.egdsocket)
|
|
#define EGD_SOCKET "" /* doesn't matter won't be used */
|
|
#endif
|
|
{
|
|
/* If there's an option and a define, the option overrides the
|
|
define */
|
|
int ret = RAND_egd(data->set.ssl.egdsocket?
|
|
data->set.ssl.egdsocket:EGD_SOCKET);
|
|
if(-1 != ret) {
|
|
nread += ret;
|
|
if(seed_enough(nread))
|
|
return nread;
|
|
}
|
|
}
|
|
#endif
|
|
|
|
/* If we get here, it means we need to seed the PRNG using a "silly"
|
|
approach! */
|
|
#ifdef HAVE_RAND_SCREEN
|
|
/* This one gets a random value by reading the currently shown screen */
|
|
RAND_screen();
|
|
nread = 100; /* just a value */
|
|
#else
|
|
{
|
|
int len;
|
|
char *area;
|
|
|
|
/* Changed call to RAND_seed to use the underlying RAND_add implementation
|
|
* directly. Do this in a loop, with the amount of additional entropy
|
|
* being dependent upon the algorithm used by Curl_FormBoundary(): N bytes
|
|
* of a 7-bit ascii set. -- Richard Gorton, March 11 2003.
|
|
*/
|
|
|
|
do {
|
|
area = Curl_FormBoundary();
|
|
if(!area)
|
|
return 3; /* out of memory */
|
|
|
|
len = strlen(area);
|
|
RAND_add(area, len, (len >> 1));
|
|
|
|
free(area); /* now remove the random junk */
|
|
} while (!RAND_status());
|
|
}
|
|
#endif
|
|
|
|
/* generates a default path for the random seed file */
|
|
buf[0]=0; /* blank it first */
|
|
RAND_file_name(buf, BUFSIZE);
|
|
if ( buf[0] ) {
|
|
/* we got a file name to try */
|
|
nread += RAND_load_file(buf, 16384);
|
|
if(seed_enough(nread))
|
|
return nread;
|
|
}
|
|
|
|
infof(data, "libcurl is now using a weak random seed!\n");
|
|
return nread;
|
|
}
|
|
|
|
#ifndef SSL_FILETYPE_ENGINE
|
|
#define SSL_FILETYPE_ENGINE 42
|
|
#endif
|
|
static int do_file_type(const char *type)
|
|
{
|
|
if (!type || !type[0])
|
|
return SSL_FILETYPE_PEM;
|
|
if (curl_strequal(type, "PEM"))
|
|
return SSL_FILETYPE_PEM;
|
|
if (curl_strequal(type, "DER"))
|
|
return SSL_FILETYPE_ASN1;
|
|
if (curl_strequal(type, "ENG"))
|
|
return SSL_FILETYPE_ENGINE;
|
|
return -1;
|
|
}
|
|
|
|
static
|
|
int cert_stuff(struct connectdata *conn,
|
|
char *cert_file,
|
|
const char *cert_type,
|
|
char *key_file,
|
|
const char *key_type)
|
|
{
|
|
struct SessionHandle *data = conn->data;
|
|
int file_type;
|
|
|
|
if (cert_file != NULL) {
|
|
SSL *ssl;
|
|
X509 *x509;
|
|
|
|
if(data->set.key_passwd) {
|
|
#ifndef HAVE_USERDATA_IN_PWD_CALLBACK
|
|
/*
|
|
* If password has been given, we store that in the global
|
|
* area (*shudder*) for a while:
|
|
*/
|
|
strcpy(global_passwd, data->set.key_passwd);
|
|
#else
|
|
/*
|
|
* We set the password in the callback userdata
|
|
*/
|
|
SSL_CTX_set_default_passwd_cb_userdata(conn->ssl.ctx,
|
|
data->set.key_passwd);
|
|
#endif
|
|
/* Set passwd callback: */
|
|
SSL_CTX_set_default_passwd_cb(conn->ssl.ctx, passwd_callback);
|
|
}
|
|
|
|
file_type = do_file_type(cert_type);
|
|
|
|
switch(file_type) {
|
|
case SSL_FILETYPE_PEM:
|
|
/* SSL_CTX_use_certificate_chain_file() only works on PEM files */
|
|
if (SSL_CTX_use_certificate_chain_file(conn->ssl.ctx,
|
|
cert_file) != 1) {
|
|
failf(data, "unable to set certificate file (wrong password?)");
|
|
return 0;
|
|
}
|
|
break;
|
|
|
|
case SSL_FILETYPE_ASN1:
|
|
/* SSL_CTX_use_certificate_file() works with either PEM or ASN1, but
|
|
we use the case above for PEM so this can only be performed with
|
|
ASN1 files. */
|
|
if (SSL_CTX_use_certificate_file(conn->ssl.ctx,
|
|
cert_file,
|
|
file_type) != 1) {
|
|
failf(data, "unable to set certificate file (wrong password?)");
|
|
return 0;
|
|
}
|
|
break;
|
|
case SSL_FILETYPE_ENGINE:
|
|
failf(data, "file type ENG for certificate not implemented");
|
|
return 0;
|
|
|
|
default:
|
|
failf(data, "not supported file type '%s' for certificate", cert_type);
|
|
return 0;
|
|
}
|
|
|
|
file_type = do_file_type(key_type);
|
|
|
|
switch(file_type) {
|
|
case SSL_FILETYPE_PEM:
|
|
if (key_file == NULL)
|
|
/* cert & key can only be in PEM case in the same file */
|
|
key_file=cert_file;
|
|
case SSL_FILETYPE_ASN1:
|
|
if (SSL_CTX_use_PrivateKey_file(conn->ssl.ctx,
|
|
key_file,
|
|
file_type) != 1) {
|
|
failf(data, "unable to set private key file: '%s' type %s\n",
|
|
key_file, key_type?key_type:"PEM");
|
|
return 0;
|
|
}
|
|
break;
|
|
case SSL_FILETYPE_ENGINE:
|
|
#ifdef HAVE_OPENSSL_ENGINE_H
|
|
{ /* XXXX still needs some work */
|
|
EVP_PKEY *priv_key = NULL;
|
|
if (conn && conn->data && conn->data->engine) {
|
|
#ifdef HAVE_ENGINE_LOAD_FOUR_ARGS
|
|
UI_METHOD *ui_method = UI_OpenSSL();
|
|
#endif
|
|
if (!key_file || !key_file[0]) {
|
|
failf(data, "no key set to load from crypto engine\n");
|
|
return 0;
|
|
}
|
|
priv_key = ENGINE_load_private_key(conn->data->engine,key_file,
|
|
#ifdef HAVE_ENGINE_LOAD_FOUR_ARGS
|
|
ui_method,
|
|
#endif
|
|
data->set.key_passwd);
|
|
if (!priv_key) {
|
|
failf(data, "failed to load private key from crypto engine\n");
|
|
return 0;
|
|
}
|
|
if (SSL_CTX_use_PrivateKey(conn->ssl.ctx, priv_key) != 1) {
|
|
failf(data, "unable to set private key\n");
|
|
EVP_PKEY_free(priv_key);
|
|
return 0;
|
|
}
|
|
EVP_PKEY_free(priv_key); /* we don't need the handle any more... */
|
|
}
|
|
else {
|
|
failf(data, "crypto engine not set, can't load private key\n");
|
|
return 0;
|
|
}
|
|
}
|
|
#else
|
|
failf(data, "file type ENG for private key not supported\n");
|
|
return 0;
|
|
#endif
|
|
break;
|
|
default:
|
|
failf(data, "not supported file type for private key\n");
|
|
return 0;
|
|
}
|
|
|
|
ssl=SSL_new(conn->ssl.ctx);
|
|
x509=SSL_get_certificate(ssl);
|
|
|
|
/* This version was provided by Evan Jordan and is supposed to not
|
|
leak memory as the previous version: */
|
|
if (x509 != NULL) {
|
|
EVP_PKEY *pktmp = X509_get_pubkey(x509);
|
|
EVP_PKEY_copy_parameters(pktmp,SSL_get_privatekey(ssl));
|
|
EVP_PKEY_free(pktmp);
|
|
}
|
|
|
|
SSL_free(ssl);
|
|
|
|
/* If we are using DSA, we can copy the parameters from
|
|
* the private key */
|
|
|
|
|
|
/* Now we know that a key and cert have been set against
|
|
* the SSL context */
|
|
if (!SSL_CTX_check_private_key(conn->ssl.ctx)) {
|
|
failf(data, "Private key does not match the certificate public key");
|
|
return(0);
|
|
}
|
|
#ifndef HAVE_USERDATA_IN_PWD_CALLBACK
|
|
/* erase it now */
|
|
memset(global_passwd, 0, sizeof(global_passwd));
|
|
#endif
|
|
}
|
|
return(1);
|
|
}
|
|
|
|
static
|
|
int cert_verify_callback(int ok, X509_STORE_CTX *ctx)
|
|
{
|
|
X509 *err_cert;
|
|
char buf[256];
|
|
|
|
err_cert=X509_STORE_CTX_get_current_cert(ctx);
|
|
X509_NAME_oneline(X509_get_subject_name(err_cert),buf,256);
|
|
|
|
return ok;
|
|
}
|
|
|
|
#endif
|
|
|
|
#ifdef USE_SSLEAY
|
|
/* "global" init done? */
|
|
static int init_ssl=0;
|
|
|
|
/* we have the "SSL is seeded" boolean global for the application to
|
|
prevent multiple time-consuming seedings in vain */
|
|
static bool ssl_seeded = FALSE;
|
|
#endif
|
|
|
|
/* Global init */
|
|
void Curl_SSL_init(void)
|
|
{
|
|
#ifdef USE_SSLEAY
|
|
/* make sure this is only done once */
|
|
if(0 != init_ssl)
|
|
return;
|
|
|
|
init_ssl++; /* never again */
|
|
|
|
#ifdef HAVE_ENGINE_LOAD_BUILTIN_ENGINES
|
|
ENGINE_load_builtin_engines();
|
|
#endif
|
|
|
|
/* Lets get nice error messages */
|
|
SSL_load_error_strings();
|
|
|
|
/* Setup all the global SSL stuff */
|
|
SSLeay_add_ssl_algorithms();
|
|
#else
|
|
/* SSL disabled, do nothing */
|
|
#endif
|
|
}
|
|
|
|
/* Global cleanup */
|
|
void Curl_SSL_cleanup(void)
|
|
{
|
|
#ifdef USE_SSLEAY
|
|
if(init_ssl) {
|
|
/* only cleanup if we did a previous init */
|
|
|
|
/* Free the SSL error strings */
|
|
ERR_free_strings();
|
|
|
|
/* EVP_cleanup() removes all ciphers and digests from the
|
|
table. */
|
|
EVP_cleanup();
|
|
|
|
#ifdef HAVE_ENGINE_cleanup
|
|
ENGINE_cleanup();
|
|
#endif
|
|
|
|
init_ssl=0; /* not inited any more */
|
|
}
|
|
#else
|
|
/* SSL disabled, do nothing */
|
|
#endif
|
|
}
|
|
|
|
#ifdef USE_SSLEAY
|
|
|
|
/*
|
|
* This function is called when an SSL connection is closed.
|
|
*/
|
|
void Curl_SSL_Close(struct connectdata *conn)
|
|
{
|
|
if (conn->ssl.use) {
|
|
/*
|
|
ERR_remove_state() frees the error queue associated with
|
|
thread pid. If pid == 0, the current thread will have its
|
|
error queue removed.
|
|
|
|
Since error queue data structures are allocated
|
|
automatically for new threads, they must be freed when
|
|
threads are terminated in oder to avoid memory leaks.
|
|
*/
|
|
ERR_remove_state(0);
|
|
|
|
if(conn->ssl.handle) {
|
|
(void)SSL_shutdown(conn->ssl.handle);
|
|
SSL_set_connect_state(conn->ssl.handle);
|
|
|
|
SSL_free (conn->ssl.handle);
|
|
conn->ssl.handle = NULL;
|
|
}
|
|
if(conn->ssl.ctx) {
|
|
SSL_CTX_free (conn->ssl.ctx);
|
|
conn->ssl.ctx = NULL;
|
|
}
|
|
conn->ssl.use = FALSE; /* get back to ordinary socket usage */
|
|
}
|
|
}
|
|
|
|
|
|
/*
|
|
* This sets up a session cache to the specified size.
|
|
*/
|
|
CURLcode Curl_SSL_InitSessions(struct SessionHandle *data, long amount)
|
|
{
|
|
struct curl_ssl_session *session;
|
|
|
|
if(data->state.session)
|
|
/* this is just a precaution to prevent multiple inits */
|
|
return CURLE_OK;
|
|
|
|
session = (struct curl_ssl_session *)
|
|
malloc(amount * sizeof(struct curl_ssl_session));
|
|
if(!session)
|
|
return CURLE_OUT_OF_MEMORY;
|
|
|
|
/* "blank out" the newly allocated memory */
|
|
memset(session, 0, amount * sizeof(struct curl_ssl_session));
|
|
|
|
/* store the info in the SSL section */
|
|
data->set.ssl.numsessions = amount;
|
|
data->state.session = session;
|
|
data->state.sessionage = 1; /* this is brand new */
|
|
|
|
return CURLE_OK;
|
|
}
|
|
|
|
/*
|
|
* Check if there's a session ID for the given connection in the cache,
|
|
* and if there's one suitable, it is returned.
|
|
*/
|
|
static int Get_SSL_Session(struct connectdata *conn,
|
|
SSL_SESSION **ssl_sessionid)
|
|
{
|
|
struct curl_ssl_session *check;
|
|
struct SessionHandle *data = conn->data;
|
|
long i;
|
|
|
|
for(i=0; i< data->set.ssl.numsessions; i++) {
|
|
check = &data->state.session[i];
|
|
if(!check->sessionid)
|
|
/* not session ID means blank entry */
|
|
continue;
|
|
if(curl_strequal(conn->name, check->name) &&
|
|
(conn->remote_port == check->remote_port) &&
|
|
Curl_ssl_config_matches(&conn->ssl_config, &check->ssl_config)) {
|
|
/* yes, we have a session ID! */
|
|
data->state.sessionage++; /* increase general age */
|
|
check->age = data->state.sessionage; /* set this as used in this age */
|
|
*ssl_sessionid = check->sessionid;
|
|
return FALSE;
|
|
}
|
|
}
|
|
*ssl_sessionid = (SSL_SESSION *)NULL;
|
|
return TRUE;
|
|
}
|
|
|
|
/*
|
|
* Kill a single session ID entry in the cache.
|
|
*/
|
|
static int Kill_Single_Session(struct curl_ssl_session *session)
|
|
{
|
|
if(session->sessionid) {
|
|
/* defensive check */
|
|
|
|
/* free the ID */
|
|
SSL_SESSION_free(session->sessionid);
|
|
session->sessionid=NULL;
|
|
session->age = 0; /* fresh */
|
|
|
|
Curl_free_ssl_config(&session->ssl_config);
|
|
|
|
free(session->name);
|
|
session->name = NULL; /* no name */
|
|
|
|
return 0; /* ok */
|
|
}
|
|
else
|
|
return 1;
|
|
}
|
|
|
|
/*
|
|
* This function is called when the 'data' struct is going away. Close
|
|
* down everything and free all resources!
|
|
*/
|
|
int Curl_SSL_Close_All(struct SessionHandle *data)
|
|
{
|
|
int i;
|
|
|
|
if(data->state.session) {
|
|
for(i=0; i< data->set.ssl.numsessions; i++)
|
|
/* the single-killer function handles empty table slots */
|
|
Kill_Single_Session(&data->state.session[i]);
|
|
|
|
/* free the cache data */
|
|
free(data->state.session);
|
|
}
|
|
#ifdef HAVE_OPENSSL_ENGINE_H
|
|
if (data->engine)
|
|
{
|
|
ENGINE_free(data->engine);
|
|
data->engine = NULL;
|
|
}
|
|
#endif
|
|
return 0;
|
|
}
|
|
|
|
/*
|
|
* Extract the session id and store it in the session cache.
|
|
*/
|
|
static int Store_SSL_Session(struct connectdata *conn)
|
|
{
|
|
SSL_SESSION *ssl_sessionid;
|
|
int i;
|
|
struct SessionHandle *data=conn->data; /* the mother of all structs */
|
|
struct curl_ssl_session *store = &data->state.session[0];
|
|
int oldest_age=data->state.session[0].age; /* zero if unused */
|
|
|
|
/* ask OpenSSL, say please */
|
|
|
|
#ifdef HAVE_SSL_GET1_SESSION
|
|
ssl_sessionid = SSL_get1_session(conn->ssl.handle);
|
|
|
|
/* SSL_get1_session() will increment the reference
|
|
count and the session will stay in memory until explicitly freed with
|
|
SSL_SESSION_free(3), regardless of its state.
|
|
This function was introduced in openssl 0.9.5a. */
|
|
#else
|
|
ssl_sessionid = SSL_get_session(conn->ssl.handle);
|
|
|
|
/* if SSL_get1_session() is unavailable, use SSL_get_session().
|
|
This is an inferior option because the session can be flushed
|
|
at any time by openssl. It is included only so curl compiles
|
|
under versions of openssl < 0.9.5a.
|
|
|
|
WARNING: How curl behaves if it's session is flushed is
|
|
untested.
|
|
*/
|
|
#endif
|
|
|
|
/* Now we should add the session ID and the host name to the cache, (remove
|
|
the oldest if necessary) */
|
|
|
|
/* find an empty slot for us, or find the oldest */
|
|
for(i=1; (i<data->set.ssl.numsessions) &&
|
|
data->state.session[i].sessionid; i++) {
|
|
if(data->state.session[i].age < oldest_age) {
|
|
oldest_age = data->state.session[i].age;
|
|
store = &data->state.session[i];
|
|
}
|
|
}
|
|
if(i == data->set.ssl.numsessions)
|
|
/* cache is full, we must "kill" the oldest entry! */
|
|
Kill_Single_Session(store);
|
|
else
|
|
store = &data->state.session[i]; /* use this slot */
|
|
|
|
/* now init the session struct wisely */
|
|
store->sessionid = ssl_sessionid;
|
|
store->age = data->state.sessionage; /* set current age */
|
|
store->name = strdup(conn->name); /* clone host name */
|
|
store->remote_port = conn->remote_port; /* port number */
|
|
|
|
Curl_clone_ssl_config(&conn->ssl_config, &store->ssl_config);
|
|
|
|
return 0;
|
|
}
|
|
|
|
static int Curl_ASN1_UTCTIME_output(struct connectdata *conn,
|
|
const char *prefix,
|
|
ASN1_UTCTIME *tm)
|
|
{
|
|
char *asn1_string;
|
|
int gmt=FALSE;
|
|
int i;
|
|
int year=0,month=0,day=0,hour=0,minute=0,second=0;
|
|
struct SessionHandle *data = conn->data;
|
|
|
|
if(!data->set.verbose)
|
|
return 0;
|
|
|
|
i=tm->length;
|
|
asn1_string=(char *)tm->data;
|
|
|
|
if (i < 10)
|
|
return 1;
|
|
if (asn1_string[i-1] == 'Z')
|
|
gmt=TRUE;
|
|
for (i=0; i<10; i++)
|
|
if ((asn1_string[i] > '9') || (asn1_string[i] < '0'))
|
|
return 2;
|
|
|
|
year= (asn1_string[0]-'0')*10+(asn1_string[1]-'0');
|
|
if (year < 50)
|
|
year+=100;
|
|
|
|
month= (asn1_string[2]-'0')*10+(asn1_string[3]-'0');
|
|
if ((month > 12) || (month < 1))
|
|
return 3;
|
|
|
|
day= (asn1_string[4]-'0')*10+(asn1_string[5]-'0');
|
|
hour= (asn1_string[6]-'0')*10+(asn1_string[7]-'0');
|
|
minute= (asn1_string[8]-'0')*10+(asn1_string[9]-'0');
|
|
|
|
if ( (asn1_string[10] >= '0') && (asn1_string[10] <= '9') &&
|
|
(asn1_string[11] >= '0') && (asn1_string[11] <= '9'))
|
|
second= (asn1_string[10]-'0')*10+(asn1_string[11]-'0');
|
|
|
|
infof(data,
|
|
"%s%04d-%02d-%02d %02d:%02d:%02d %s\n",
|
|
prefix, year+1900, month, day, hour, minute, second, (gmt?"GMT":""));
|
|
|
|
return 0;
|
|
}
|
|
|
|
#endif
|
|
|
|
/* ====================================================== */
|
|
#ifdef USE_SSLEAY
|
|
static int
|
|
cert_hostcheck(const char *certname, const char *hostname)
|
|
{
|
|
char *tmp;
|
|
const char *certdomain;
|
|
|
|
if(!certname ||
|
|
strlen(certname)<3 ||
|
|
!hostname ||
|
|
!strlen(hostname)) /* sanity check */
|
|
return 0;
|
|
|
|
if(curl_strequal(certname, hostname)) /* trivial case */
|
|
return 1;
|
|
|
|
certdomain = certname + 1;
|
|
|
|
if((certname[0] != '*') || (certdomain[0] != '.'))
|
|
return 0; /* not a wildcard certificate, check failed */
|
|
|
|
if(!strchr(certdomain+1, '.'))
|
|
return 0; /* the certificate must have at least another dot in its name */
|
|
|
|
/* find 'certdomain' within 'hostname' */
|
|
tmp = strstr(hostname, certdomain);
|
|
if(tmp) {
|
|
/* ok the certname's domain matches the hostname, let's check that it's a
|
|
tail-match */
|
|
if(curl_strequal(tmp, certdomain))
|
|
/* looks like a match. Just check we havent swallowed a '.' */
|
|
return tmp == strchr(hostname, '.');
|
|
else
|
|
return 0;
|
|
}
|
|
return 0;
|
|
}
|
|
#endif
|
|
|
|
/* ====================================================== */
|
|
CURLcode
|
|
Curl_SSLConnect(struct connectdata *conn)
|
|
{
|
|
CURLcode retcode = CURLE_OK;
|
|
|
|
#ifdef USE_SSLEAY
|
|
struct SessionHandle *data = conn->data;
|
|
int err;
|
|
int what;
|
|
char * str;
|
|
SSL_METHOD *req_method;
|
|
SSL_SESSION *ssl_sessionid=NULL;
|
|
ASN1_TIME *certdate;
|
|
|
|
/* mark this is being ssl enabled from here on out. */
|
|
conn->ssl.use = TRUE;
|
|
|
|
if(!ssl_seeded || data->set.ssl.random_file || data->set.ssl.egdsocket) {
|
|
/* Make funny stuff to get random input */
|
|
random_the_seed(data);
|
|
|
|
ssl_seeded = TRUE;
|
|
}
|
|
|
|
/* check to see if we've been told to use an explicit SSL/TLS version */
|
|
switch(data->set.ssl.version) {
|
|
default:
|
|
case CURL_SSLVERSION_DEFAULT:
|
|
/* we try to figure out version */
|
|
req_method = SSLv23_client_method();
|
|
break;
|
|
case CURL_SSLVERSION_TLSv1:
|
|
req_method = TLSv1_client_method();
|
|
break;
|
|
case CURL_SSLVERSION_SSLv2:
|
|
req_method = SSLv2_client_method();
|
|
break;
|
|
case CURL_SSLVERSION_SSLv3:
|
|
req_method = SSLv3_client_method();
|
|
break;
|
|
}
|
|
|
|
conn->ssl.ctx = SSL_CTX_new(req_method);
|
|
|
|
if(!conn->ssl.ctx) {
|
|
failf(data, "SSL: couldn't create a context!");
|
|
return CURLE_OUT_OF_MEMORY;
|
|
}
|
|
|
|
if(data->set.cert) {
|
|
if (!cert_stuff(conn,
|
|
data->set.cert,
|
|
data->set.cert_type,
|
|
data->set.key,
|
|
data->set.key_type)) {
|
|
/* failf() is already done in cert_stuff() */
|
|
return CURLE_SSL_CERTPROBLEM;
|
|
}
|
|
}
|
|
|
|
if(data->set.ssl.cipher_list) {
|
|
if (!SSL_CTX_set_cipher_list(conn->ssl.ctx,
|
|
data->set.ssl.cipher_list)) {
|
|
failf(data, "failed setting cipher list");
|
|
return CURLE_SSL_CIPHER;
|
|
}
|
|
}
|
|
|
|
if(data->set.ssl.verifypeer){
|
|
SSL_CTX_set_verify(conn->ssl.ctx,
|
|
SSL_VERIFY_PEER|SSL_VERIFY_FAIL_IF_NO_PEER_CERT|
|
|
SSL_VERIFY_CLIENT_ONCE,
|
|
cert_verify_callback);
|
|
if ((data->set.ssl.CAfile || data->set.ssl.CApath) &&
|
|
!SSL_CTX_load_verify_locations(conn->ssl.ctx,
|
|
data->set.ssl.CAfile,
|
|
data->set.ssl.CApath)) {
|
|
failf(data,"error setting certificate verify locations");
|
|
return CURLE_SSL_CACERT;
|
|
}
|
|
}
|
|
else
|
|
SSL_CTX_set_verify(conn->ssl.ctx, SSL_VERIFY_NONE, cert_verify_callback);
|
|
|
|
|
|
/* Lets make an SSL structure */
|
|
conn->ssl.handle = SSL_new (conn->ssl.ctx);
|
|
SSL_set_connect_state (conn->ssl.handle);
|
|
|
|
conn->ssl.server_cert = 0x0;
|
|
|
|
if(!conn->bits.reuse) {
|
|
/* We're not re-using a connection, check if there's a cached ID we
|
|
can/should use here! */
|
|
if(!Get_SSL_Session(conn, &ssl_sessionid)) {
|
|
/* we got a session id, use it! */
|
|
SSL_set_session(conn->ssl.handle, ssl_sessionid);
|
|
/* Informational message */
|
|
infof (data, "SSL re-using session ID\n");
|
|
}
|
|
}
|
|
|
|
/* pass the raw socket into the SSL layers */
|
|
SSL_set_fd(conn->ssl.handle, conn->firstsocket);
|
|
|
|
do {
|
|
fd_set writefd;
|
|
fd_set readfd;
|
|
struct timeval interval;
|
|
long timeout_ms;
|
|
|
|
/* Find out if any timeout is set. If not, use 300 seconds.
|
|
Otherwise, figure out the most strict timeout of the two possible one
|
|
and then how much time that has elapsed to know how much time we
|
|
allow for the connect call */
|
|
if(data->set.timeout || data->set.connecttimeout) {
|
|
double has_passed;
|
|
|
|
/* Evaluate in milliseconds how much time that has passed */
|
|
has_passed = Curl_tvdiff(Curl_tvnow(), data->progress.start);
|
|
|
|
#ifndef min
|
|
#define min(a, b) ((a) < (b) ? (a) : (b))
|
|
#endif
|
|
|
|
/* get the most strict timeout of the ones converted to milliseconds */
|
|
if(data->set.timeout &&
|
|
(data->set.timeout>data->set.connecttimeout))
|
|
timeout_ms = data->set.timeout*1000;
|
|
else
|
|
timeout_ms = data->set.connecttimeout*1000;
|
|
|
|
/* subtract the passed time */
|
|
timeout_ms -= (long)has_passed;
|
|
|
|
if(timeout_ms < 0) {
|
|
/* a precaution, no need to continue if time already is up */
|
|
failf(data, "SSL connection timeout");
|
|
return CURLE_OPERATION_TIMEOUTED;
|
|
}
|
|
}
|
|
else
|
|
/* no particular time-out has been set */
|
|
timeout_ms=300000; /* milliseconds, default to five minutes */
|
|
|
|
|
|
FD_ZERO(&writefd);
|
|
FD_ZERO(&readfd);
|
|
|
|
err = SSL_connect(conn->ssl.handle);
|
|
|
|
/* 1 is fine
|
|
0 is "not successful but was shut down controlled"
|
|
<0 is "handshake was not successful, because a fatal error occurred" */
|
|
if(1 != err) {
|
|
int detail = SSL_get_error(conn->ssl.handle, err);
|
|
|
|
if(SSL_ERROR_WANT_READ == detail)
|
|
FD_SET(conn->firstsocket, &readfd);
|
|
else if(SSL_ERROR_WANT_WRITE == detail)
|
|
FD_SET(conn->firstsocket, &writefd);
|
|
else {
|
|
/* untreated error */
|
|
char error_buffer[120]; /* OpenSSL documents that this must be at least
|
|
120 bytes long. */
|
|
|
|
detail = ERR_get_error(); /* Gets the earliest error code from the
|
|
thread's error queue and removes the
|
|
entry. */
|
|
|
|
switch(detail) {
|
|
case 0x1407E086:
|
|
/* 1407E086:
|
|
SSL routines:
|
|
SSL2_SET_CERTIFICATE:
|
|
certificate verify failed */
|
|
case 0x14090086:
|
|
/* 14090086:
|
|
SSL routines:
|
|
SSL3_GET_SERVER_CERTIFICATE:
|
|
certificate verify failed */
|
|
failf(data,
|
|
"SSL certificate problem, verify that the CA cert is OK");
|
|
return CURLE_SSL_CACERT;
|
|
default:
|
|
/* detail is already set to the SSL error above */
|
|
failf(data, "SSL: %s", ERR_error_string(detail, error_buffer));
|
|
/* OpenSSL 0.9.6 and later has a function named
|
|
ERRO_error_string_n() that takes the size of the buffer as a third
|
|
argument, and we should possibly switch to using that one in the
|
|
future. */
|
|
return CURLE_SSL_CONNECT_ERROR;
|
|
}
|
|
}
|
|
}
|
|
else
|
|
/* we have been connected fine, get out of the connect loop */
|
|
break;
|
|
|
|
interval.tv_sec = timeout_ms/1000;
|
|
timeout_ms -= interval.tv_sec*1000;
|
|
|
|
interval.tv_usec = timeout_ms*1000;
|
|
|
|
what = select(conn->firstsocket+1, &readfd, &writefd, NULL, &interval);
|
|
if(what > 0)
|
|
/* reabable or writable, go loop yourself */
|
|
continue;
|
|
else if(0 == what) {
|
|
/* timeout */
|
|
failf(data, "SSL connection timeout");
|
|
return CURLE_OPERATION_TIMEOUTED;
|
|
}
|
|
else
|
|
break; /* get out of loop */
|
|
} while(1);
|
|
|
|
/* Informational message */
|
|
infof (data, "SSL connection using %s\n",
|
|
SSL_get_cipher(conn->ssl.handle));
|
|
|
|
if(!ssl_sessionid) {
|
|
/* Since this is not a cached session ID, then we want to stach this one
|
|
in the cache! */
|
|
Store_SSL_Session(conn);
|
|
}
|
|
|
|
|
|
/* Get server's certificate (note: beware of dynamic allocation) - opt */
|
|
/* major serious hack alert -- we should check certificates
|
|
* to authenticate the server; otherwise we risk man-in-the-middle
|
|
* attack
|
|
*/
|
|
|
|
conn->ssl.server_cert = SSL_get_peer_certificate (conn->ssl.handle);
|
|
if(!conn->ssl.server_cert) {
|
|
failf(data, "SSL: couldn't get peer certificate!");
|
|
return CURLE_SSL_PEER_CERTIFICATE;
|
|
}
|
|
infof (data, "Server certificate:\n");
|
|
|
|
str = X509_NAME_oneline (X509_get_subject_name (conn->ssl.server_cert),
|
|
NULL, 0);
|
|
if(!str) {
|
|
failf(data, "SSL: couldn't get X509-subject!");
|
|
X509_free(conn->ssl.server_cert);
|
|
return CURLE_SSL_CONNECT_ERROR;
|
|
}
|
|
infof(data, "\t subject: %s\n", str);
|
|
CRYPTO_free(str);
|
|
|
|
certdate = X509_get_notBefore(conn->ssl.server_cert);
|
|
Curl_ASN1_UTCTIME_output(conn, "\t start date: ", certdate);
|
|
|
|
certdate = X509_get_notAfter(conn->ssl.server_cert);
|
|
Curl_ASN1_UTCTIME_output(conn, "\t expire date: ", certdate);
|
|
|
|
if (data->set.ssl.verifyhost) {
|
|
char peer_CN[257];
|
|
if (X509_NAME_get_text_by_NID(X509_get_subject_name(conn->ssl.server_cert),
|
|
NID_commonName,
|
|
peer_CN,
|
|
sizeof(peer_CN)) < 0) {
|
|
failf(data, "SSL: unable to obtain common name from peer certificate");
|
|
X509_free(conn->ssl.server_cert);
|
|
return CURLE_SSL_PEER_CERTIFICATE;
|
|
}
|
|
|
|
if (!cert_hostcheck(peer_CN, conn->hostname)) {
|
|
if (data->set.ssl.verifyhost > 1) {
|
|
failf(data, "SSL: certificate subject name '%s' does not match "
|
|
"target host name '%s'",
|
|
peer_CN, conn->hostname);
|
|
X509_free(conn->ssl.server_cert);
|
|
return CURLE_SSL_PEER_CERTIFICATE;
|
|
}
|
|
else
|
|
infof(data,
|
|
"\t common name: %s (does not match '%s')\n",
|
|
peer_CN, conn->hostname);
|
|
}
|
|
else
|
|
infof(data, "\t common name: %s (matched)\n", peer_CN);
|
|
}
|
|
|
|
str = X509_NAME_oneline (X509_get_issuer_name (conn->ssl.server_cert),
|
|
NULL, 0);
|
|
if(!str) {
|
|
failf(data, "SSL: couldn't get X509-issuer name!");
|
|
X509_free(conn->ssl.server_cert);
|
|
return CURLE_SSL_CONNECT_ERROR;
|
|
}
|
|
infof(data, "\t issuer: %s\n", str);
|
|
CRYPTO_free(str);
|
|
|
|
/* We could do all sorts of certificate verification stuff here before
|
|
deallocating the certificate. */
|
|
|
|
if(data->set.ssl.verifypeer) {
|
|
data->set.ssl.certverifyresult=SSL_get_verify_result(conn->ssl.handle);
|
|
if (data->set.ssl.certverifyresult != X509_V_OK) {
|
|
failf(data, "SSL certificate verify result: %d",
|
|
data->set.ssl.certverifyresult);
|
|
retcode = CURLE_SSL_PEER_CERTIFICATE;
|
|
}
|
|
}
|
|
else
|
|
data->set.ssl.certverifyresult=0;
|
|
|
|
X509_free(conn->ssl.server_cert);
|
|
#else /* USE_SSLEAY */
|
|
/* this is for "-ansi -Wall -pedantic" to stop complaining! (rabe) */
|
|
(void) conn;
|
|
#endif
|
|
return retcode;
|
|
}
|