]> git.netwichtig.de Git - user/henk/code/inspircd.git/blobdiff - src/modules/extra/m_ssl_openssl.cpp
m_ssl_openssl Return an error from the IOHook read and write functions if the handsha...
[user/henk/code/inspircd.git] / src / modules / extra / m_ssl_openssl.cpp
index fa9442a00d89024207c36498d143d5f7f31d3088..e9b5c4052e1858e0472add603aa70138880bd14f 100644 (file)
  * along with this program.  If not, see <http://www.gnu.org/licenses/>.
  */
 
-
+ /* HACK: This prevents OpenSSL on OS X 10.7 and later from spewing deprecation
+  * warnings for every single function call. As far as I (SaberUK) know, Apple
+  * have no plans to remove OpenSSL so this warning just causes needless spam.
+  */
+#ifdef __APPLE__
+# define __AVAILABILITYMACROS__
+# define DEPRECATED_IN_MAC_OS_X_VERSION_10_7_AND_LATER
+#endif
 #include "inspircd.h"
 #include <openssl/ssl.h>
 #include <openssl/err.h>
 #include "ssl.h"
 
-#ifdef WINDOWS
-# pragma comment(lib, "libcrypto.lib")
-# pragma comment(lib, "libssl.lib")
-# pragma comment(lib, "user32.lib")
-# pragma comment(lib, "advapi32.lib")
-# pragma comment(lib, "libgcc.lib")
-# pragma comment(lib, "libmingwex.lib")
-# pragma comment(lib, "gdi32.lib")
+#ifdef _WIN32
+# pragma comment(lib, "ssleay32.lib")
+# pragma comment(lib, "libeay32.lib")
 # undef MAX_DESCRIPTORS
 # define MAX_DESCRIPTORS 10000
 #endif
@@ -68,7 +71,6 @@ public:
        issl_status status;
        reference<ssl_cert> cert;
 
-       int fd;
        bool outbound;
        bool data_to_write;
 
@@ -95,27 +97,54 @@ static int OnVerify(int preverify_ok, X509_STORE_CTX *ctx)
 
 class ModuleSSLOpenSSL : public Module
 {
-       int inbufsize;
        issl_session* sessions;
 
        SSL_CTX* ctx;
        SSL_CTX* clictx;
 
-       char cipher[MAXBUF];
+       long ctx_options;
+       long clictx_options;
 
        std::string sslports;
        bool use_sha;
 
        ServiceProvider iohook;
+
+       static void SetContextOptions(SSL_CTX* ctx, long defoptions, const std::string& ctxname, ConfigTag* tag)
+       {
+               long setoptions = tag->getInt(ctxname + "setoptions");
+               // User-friendly config options for setting context options
+#ifdef SSL_OP_CIPHER_SERVER_PREFERENCE
+               if (tag->getBool("cipherserverpref"))
+                       setoptions |= SSL_OP_CIPHER_SERVER_PREFERENCE;
+#endif
+#ifdef SSL_OP_NO_COMPRESSION
+               if (!tag->getBool("compression", true))
+                       setoptions |= SSL_OP_NO_COMPRESSION;
+#endif
+               if (!tag->getBool("sslv3", true))
+                       setoptions |= SSL_OP_NO_SSLv3;
+               if (!tag->getBool("tlsv1", true))
+                       setoptions |= SSL_OP_NO_TLSv1;
+
+               long clearoptions = tag->getInt(ctxname + "clearoptions");
+               ServerInstance->Logs->Log("m_ssl_openssl", DEBUG, "Setting OpenSSL %s context options, default: %ld set: %ld clear: %ld", ctxname.c_str(), defoptions, clearoptions, setoptions);
+
+               // Clear everything
+               SSL_CTX_clear_options(ctx, SSL_CTX_get_options(ctx));
+
+               // Set the default options and what is in the conf
+               SSL_CTX_set_options(ctx, defoptions | setoptions);
+               long final = SSL_CTX_clear_options(ctx, clearoptions);
+               ServerInstance->Logs->Log("m_ssl_openssl", DEFAULT, "OpenSSL %s context options: %ld", ctxname.c_str(), final);
+       }
+
  public:
 
        ModuleSSLOpenSSL() : iohook(this, "ssl/openssl", SERVICE_IOHOOK)
        {
                sessions = new issl_session[ServerInstance->SE->GetMaxFds()];
 
-               // Not rehashable...because I cba to reduce all the sizes of existing buffers.
-               inbufsize = ServerInstance->Config->NetBufferSize;
-
                /* Global SSL library initialization*/
                SSL_library_init();
                SSL_load_error_strings();
@@ -131,6 +160,21 @@ class ModuleSSLOpenSSL : public Module
 
                SSL_CTX_set_verify(ctx, SSL_VERIFY_PEER | SSL_VERIFY_CLIENT_ONCE, OnVerify);
                SSL_CTX_set_verify(clictx, SSL_VERIFY_PEER | SSL_VERIFY_CLIENT_ONCE, OnVerify);
+
+               SSL_CTX_set_session_cache_mode(ctx, SSL_SESS_CACHE_OFF);
+               SSL_CTX_set_session_cache_mode(clictx, SSL_SESS_CACHE_OFF);
+
+               long opts = SSL_OP_NO_SSLv2 | SSL_OP_SINGLE_DH_USE;
+               // Only turn options on if they exist
+#ifdef SSL_OP_SINGLE_ECDH_USE
+               opts |= SSL_OP_SINGLE_ECDH_USE;
+#endif
+#ifdef SSL_OP_NO_TICKET
+               opts |= SSL_OP_NO_TICKET;
+#endif
+
+               ctx_options = SSL_CTX_set_options(ctx, opts);
+               clictx_options = SSL_CTX_set_options(clictx, opts);
        }
 
        void init()
@@ -156,23 +200,37 @@ class ModuleSSLOpenSSL : public Module
                sslports.clear();
 
                ConfigTag* Conf = ServerInstance->Config->ConfValue("openssl");
-               
+
                if (Conf->getBool("showports", true))
                {
+                       sslports = Conf->getString("advertisedports");
+                       if (!sslports.empty())
+                               return;
+
                        for (size_t i = 0; i < ServerInstance->ports.size(); i++)
                        {
                                ListenSocket* port = ServerInstance->ports[i];
                                if (port->bind_tag->getString("ssl") != "openssl")
                                        continue;
 
-                               std::string portid = port->bind_desc;
+                               const std::string& portid = port->bind_desc;
                                ServerInstance->Logs->Log("m_ssl_openssl", DEFAULT, "m_ssl_openssl.so: Enabling SSL for port %s", portid.c_str());
+
                                if (port->bind_tag->getString("type", "clients") == "clients" && port->bind_addr != "127.0.0.1")
-                                       sslports.append(portid).append(";");
+                               {
+                                       /*
+                                        * Found an SSL port for clients that is not bound to 127.0.0.1 and handled by us, display
+                                        * the IP:port in ISUPPORT.
+                                        *
+                                        * We used to advertise all ports seperated by a ';' char that matched the above criteria,
+                                        * but this resulted in too long ISUPPORT lines if there were lots of ports to be displayed.
+                                        * To solve this by default we now only display the first IP:port found and let the user
+                                        * configure the exact value for the 005 token, if necessary.
+                                        */
+                                       sslports = portid;
+                                       break;
+                               }
                        }
-
-                       if (!sslports.empty())
-                               sslports.erase(sslports.end() - 1);
                }
        }
 
@@ -189,32 +247,44 @@ class ModuleSSLOpenSSL : public Module
 
                ConfigTag* conf = ServerInstance->Config->ConfValue("openssl");
 
-               cafile   = conf->getString("cafile", "conf/ca.pem");
-               certfile = conf->getString("certfile", "conf/cert.pem");
-               keyfile  = conf->getString("keyfile", "conf/key.pem");
-               dhfile   = conf->getString("dhfile", "conf/dhparams.pem");
+               cafile   = conf->getString("cafile", CONFIG_PATH "/ca.pem");
+               certfile = conf->getString("certfile", CONFIG_PATH "/cert.pem");
+               keyfile  = conf->getString("keyfile", CONFIG_PATH "/key.pem");
+               dhfile   = conf->getString("dhfile", CONFIG_PATH "/dhparams.pem");
                std::string hash = conf->getString("hash", "md5");
                if (hash != "sha1" && hash != "md5")
                        throw ModuleException("Unknown hash type " + hash);
                use_sha = (hash == "sha1");
 
-               std::string ciphers = conf->getString("ciphers", "ALL");
-               if ((!SSL_CTX_set_cipher_list(ctx, ciphers.c_str())) || (!SSL_CTX_set_cipher_list(clictx, ciphers.c_str())))
+               if (conf->getBool("customcontextoptions"))
                {
-                       ServerInstance->Logs->Log("m_ssl_openssl",DEFAULT, "m_ssl_openssl.so: Can't set cipher list to %s.", ciphers.c_str());
-                       ERR_print_errors_cb(error_callback, this);
+                       SetContextOptions(ctx, ctx_options, "server", conf);
+                       SetContextOptions(clictx, clictx_options, "client", conf);
                }
 
+               std::string ciphers = conf->getString("ciphers", "");
+
+               if (!ciphers.empty())
+               {
+                       ERR_clear_error();
+                       if ((!SSL_CTX_set_cipher_list(ctx, ciphers.c_str())) || (!SSL_CTX_set_cipher_list(clictx, ciphers.c_str())))
+                       {
+                               ServerInstance->Logs->Log("m_ssl_openssl",DEFAULT, "m_ssl_openssl.so: Can't set cipher list to %s.", ciphers.c_str());
+                               ERR_print_errors_cb(error_callback, this);
+                       }
+               }
 
                /* Load our keys and certificates
                 * NOTE: OpenSSL's error logging API sucks, don't blame us for this clusterfuck.
                 */
+               ERR_clear_error();
                if ((!SSL_CTX_use_certificate_chain_file(ctx, certfile.c_str())) || (!SSL_CTX_use_certificate_chain_file(clictx, certfile.c_str())))
                {
                        ServerInstance->Logs->Log("m_ssl_openssl",DEFAULT, "m_ssl_openssl.so: Can't read certificate file %s. %s", certfile.c_str(), strerror(errno));
                        ERR_print_errors_cb(error_callback, this);
                }
 
+               ERR_clear_error();
                if (((!SSL_CTX_use_PrivateKey_file(ctx, keyfile.c_str(), SSL_FILETYPE_PEM))) || (!SSL_CTX_use_PrivateKey_file(clictx, keyfile.c_str(), SSL_FILETYPE_PEM)))
                {
                        ServerInstance->Logs->Log("m_ssl_openssl",DEFAULT, "m_ssl_openssl.so: Can't read key file %s. %s", keyfile.c_str(), strerror(errno));
@@ -222,13 +292,18 @@ class ModuleSSLOpenSSL : public Module
                }
 
                /* Load the CAs we trust*/
+               ERR_clear_error();
                if (((!SSL_CTX_load_verify_locations(ctx, cafile.c_str(), 0))) || (!SSL_CTX_load_verify_locations(clictx, cafile.c_str(), 0)))
                {
-                       ServerInstance->Logs->Log("m_ssl_openssl",DEFAULT, "m_ssl_openssl.so: Can't read CA list from %s. %s", cafile.c_str(), strerror(errno));
+                       ServerInstance->Logs->Log("m_ssl_openssl",DEFAULT, "m_ssl_openssl.so: Can't read CA list from %s. This is only a problem if you want to verify client certificates, otherwise it's safe to ignore this message. Error: %s", cafile.c_str(), strerror(errno));
                        ERR_print_errors_cb(error_callback, this);
                }
 
+#ifdef _WIN32
+               BIO* dhpfile = BIO_new_file(dhfile.c_str(), "r");
+#else
                FILE* dhpfile = fopen(dhfile.c_str(), "r");
+#endif
                DH* ret;
 
                if (dhpfile == NULL)
@@ -238,15 +313,25 @@ class ModuleSSLOpenSSL : public Module
                }
                else
                {
+#ifdef _WIN32
+                       ret = PEM_read_bio_DHparams(dhpfile, NULL, NULL, NULL);
+                       BIO_free(dhpfile);
+#else
                        ret = PEM_read_DHparams(dhpfile, NULL, NULL, NULL);
+#endif
+
+                       ERR_clear_error();
                        if ((SSL_CTX_set_tmp_dh(ctx, ret) < 0) || (SSL_CTX_set_tmp_dh(clictx, ret) < 0))
                        {
                                ServerInstance->Logs->Log("m_ssl_openssl",DEFAULT, "m_ssl_openssl.so: Couldn't set DH parameters %s. SSL errors follow:", dhfile.c_str());
                                ERR_print_errors_cb(error_callback, this);
                        }
+                       DH_free(ret);
                }
 
+#ifndef _WIN32
                fclose(dhpfile);
+#endif
        }
 
        void On005Numeric(std::string &output)
@@ -315,7 +400,6 @@ class ModuleSSLOpenSSL : public Module
 
                issl_session* session = &sessions[fd];
 
-               session->fd = fd;
                session->sess = SSL_new(ctx);
                session->status = ISSL_NONE;
                session->outbound = false;
@@ -342,7 +426,6 @@ class ModuleSSLOpenSSL : public Module
 
                issl_session* session = &sessions[fd];
 
-               session->fd = fd;
                session->sess = SSL_new(clictx);
                session->status = ISSL_NONE;
                session->outbound = true;
@@ -400,6 +483,7 @@ class ModuleSSLOpenSSL : public Module
 
                if (session->status == ISSL_OPEN)
                {
+                       ERR_clear_error();
                        char* buffer = ServerInstance->GetReadBuffer();
                        size_t bufsiz = ServerInstance->Config->NetBufferSize;
                        int ret = SSL_read(session->sess, buffer, bufsiz);
@@ -415,6 +499,7 @@ class ModuleSSLOpenSSL : public Module
                        {
                                // Client closed connection.
                                CloseSession(session);
+                               user->SetError("Connection closed");
                                return -1;
                        }
                        else if (ret < 0)
@@ -469,6 +554,7 @@ class ModuleSSLOpenSSL : public Module
 
                if (session->status == ISSL_OPEN)
                {
+                       ERR_clear_error();
                        int ret = SSL_write(session->sess, buffer.data(), buffer.size());
                        if (ret == (int)buffer.length())
                        {
@@ -515,6 +601,7 @@ class ModuleSSLOpenSSL : public Module
        {
                int ret;
 
+               ERR_clear_error();
                if (session->outbound)
                        ret = SSL_connect(session->sess);
                else
@@ -557,7 +644,7 @@ class ModuleSSLOpenSSL : public Module
                else if (ret == 0)
                {
                        CloseSession(session);
-                       return true;
+                       return false;
                }
 
                return true;
@@ -598,7 +685,7 @@ class ModuleSSLOpenSSL : public Module
 
                certinfo->invalid = (SSL_get_verify_result(session->sess) != X509_V_OK);
 
-               if (SelfSigned)
+               if (!SelfSigned)
                {
                        certinfo->unknownsigner = false;
                        certinfo->trusted = true;
@@ -609,8 +696,17 @@ class ModuleSSLOpenSSL : public Module
                        certinfo->trusted = false;
                }
 
-               certinfo->dn = X509_NAME_oneline(X509_get_subject_name(cert),0,0);
-               certinfo->issuer = X509_NAME_oneline(X509_get_issuer_name(cert),0,0);
+               char buf[512];
+               X509_NAME_oneline(X509_get_subject_name(cert), buf, sizeof(buf));
+               certinfo->dn = buf;
+               // Make sure there are no chars in the string that we consider invalid
+               if (certinfo->dn.find_first_of("\r\n") != std::string::npos)
+                       certinfo->dn.clear();
+
+               X509_NAME_oneline(X509_get_issuer_name(cert), buf, sizeof(buf));
+               certinfo->issuer = buf;
+               if (certinfo->issuer.find_first_of("\r\n") != std::string::npos)
+                       certinfo->issuer.clear();
 
                if (!X509_digest(cert, digest, md, &n))
                {