1 | /*************************************************************************** |
2 | * _ _ ____ _ |
3 | * Project ___| | | | _ \| | |
4 | * / __| | | | |_) | | |
5 | * | (__| |_| | _ <| |___ |
6 | * \___|\___/|_| \_\_____| |
7 | * |
8 | * Copyright (C) 1998 - 2019, Daniel Stenberg, <daniel@haxx.se>, et al. |
9 | * |
10 | * This software is licensed as described in the file COPYING, which |
11 | * you should have received as part of this distribution. The terms |
12 | * are also available at https://curl.haxx.se/docs/copyright.html. |
13 | * |
14 | * You may opt to use, copy, modify, merge, publish, distribute and/or sell |
15 | * copies of the Software, and permit persons to whom the Software is |
16 | * furnished to do so, under the terms of the COPYING file. |
17 | * |
18 | * This software is distributed on an "AS IS" basis, WITHOUT WARRANTY OF ANY |
19 | * KIND, either express or implied. |
20 | * |
21 | ***************************************************************************/ |
22 | |
23 | /* |
24 | * Source file for all NSS-specific code for the TLS/SSL layer. No code |
25 | * but vtls.c should ever call or use these functions. |
26 | */ |
27 | |
28 | #include "curl_setup.h" |
29 | |
30 | #ifdef USE_NSS |
31 | |
32 | #include "urldata.h" |
33 | #include "sendf.h" |
34 | #include "formdata.h" /* for the boundary function */ |
35 | #include "url.h" /* for the ssl config check function */ |
36 | #include "connect.h" |
37 | #include "strcase.h" |
38 | #include "select.h" |
39 | #include "vtls.h" |
40 | #include "llist.h" |
41 | #include "multiif.h" |
42 | #include "curl_printf.h" |
43 | #include "nssg.h" |
44 | #include <nspr.h> |
45 | #include <nss.h> |
46 | #include <ssl.h> |
47 | #include <sslerr.h> |
48 | #include <secerr.h> |
49 | #include <secmod.h> |
50 | #include <sslproto.h> |
51 | #include <prtypes.h> |
52 | #include <pk11pub.h> |
53 | #include <prio.h> |
54 | #include <secitem.h> |
55 | #include <secport.h> |
56 | #include <certdb.h> |
57 | #include <base64.h> |
58 | #include <cert.h> |
59 | #include <prerror.h> |
60 | #include <keyhi.h> /* for SECKEY_DestroyPublicKey() */ |
61 | #include <private/pprio.h> /* for PR_ImportTCPSocket */ |
62 | |
63 | #define NSSVERNUM ((NSS_VMAJOR<<16)|(NSS_VMINOR<<8)|NSS_VPATCH) |
64 | |
65 | #if NSSVERNUM >= 0x030f00 /* 3.15.0 */ |
66 | #include <ocsp.h> |
67 | #endif |
68 | |
69 | #include "strcase.h" |
70 | #include "warnless.h" |
71 | #include "x509asn1.h" |
72 | |
73 | /* The last #include files should be: */ |
74 | #include "curl_memory.h" |
75 | #include "memdebug.h" |
76 | |
77 | #define SSL_DIR "/etc/pki/nssdb" |
78 | |
79 | /* enough to fit the string "PEM Token #[0|1]" */ |
80 | #define SLOTSIZE 13 |
81 | |
82 | struct ssl_backend_data { |
83 | PRFileDesc *handle; |
84 | char *client_nickname; |
85 | struct Curl_easy *data; |
86 | struct curl_llist obj_list; |
87 | PK11GenericObject *obj_clicert; |
88 | }; |
89 | |
90 | #define BACKEND connssl->backend |
91 | |
92 | static PRLock *nss_initlock = NULL; |
93 | static PRLock *nss_crllock = NULL; |
94 | static PRLock *nss_findslot_lock = NULL; |
95 | static PRLock *nss_trustload_lock = NULL; |
96 | static struct curl_llist nss_crl_list; |
97 | static NSSInitContext *nss_context = NULL; |
98 | static volatile int initialized = 0; |
99 | |
100 | /* type used to wrap pointers as list nodes */ |
101 | struct ptr_list_wrap { |
102 | void *ptr; |
103 | struct curl_llist_element node; |
104 | }; |
105 | |
106 | typedef struct { |
107 | const char *name; |
108 | int num; |
109 | } cipher_s; |
110 | |
111 | #define PK11_SETATTRS(_attr, _idx, _type, _val, _len) do { \ |
112 | CK_ATTRIBUTE *ptr = (_attr) + ((_idx)++); \ |
113 | ptr->type = (_type); \ |
114 | ptr->pValue = (_val); \ |
115 | ptr->ulValueLen = (_len); \ |
116 | } while(0) |
117 | |
118 | #define CERT_NewTempCertificate __CERT_NewTempCertificate |
119 | |
120 | #define NUM_OF_CIPHERS sizeof(cipherlist)/sizeof(cipherlist[0]) |
121 | static const cipher_s cipherlist[] = { |
122 | /* SSL2 cipher suites */ |
123 | {"rc4" , SSL_EN_RC4_128_WITH_MD5}, |
124 | {"rc4-md5" , SSL_EN_RC4_128_WITH_MD5}, |
125 | {"rc4export" , SSL_EN_RC4_128_EXPORT40_WITH_MD5}, |
126 | {"rc2" , SSL_EN_RC2_128_CBC_WITH_MD5}, |
127 | {"rc2export" , SSL_EN_RC2_128_CBC_EXPORT40_WITH_MD5}, |
128 | {"des" , SSL_EN_DES_64_CBC_WITH_MD5}, |
129 | {"desede3" , SSL_EN_DES_192_EDE3_CBC_WITH_MD5}, |
130 | /* SSL3/TLS cipher suites */ |
131 | {"rsa_rc4_128_md5" , SSL_RSA_WITH_RC4_128_MD5}, |
132 | {"rsa_rc4_128_sha" , SSL_RSA_WITH_RC4_128_SHA}, |
133 | {"rsa_3des_sha" , SSL_RSA_WITH_3DES_EDE_CBC_SHA}, |
134 | {"rsa_des_sha" , SSL_RSA_WITH_DES_CBC_SHA}, |
135 | {"rsa_rc4_40_md5" , SSL_RSA_EXPORT_WITH_RC4_40_MD5}, |
136 | {"rsa_rc2_40_md5" , SSL_RSA_EXPORT_WITH_RC2_CBC_40_MD5}, |
137 | {"rsa_null_md5" , SSL_RSA_WITH_NULL_MD5}, |
138 | {"rsa_null_sha" , SSL_RSA_WITH_NULL_SHA}, |
139 | {"fips_3des_sha" , SSL_RSA_FIPS_WITH_3DES_EDE_CBC_SHA}, |
140 | {"fips_des_sha" , SSL_RSA_FIPS_WITH_DES_CBC_SHA}, |
141 | {"fortezza" , SSL_FORTEZZA_DMS_WITH_FORTEZZA_CBC_SHA}, |
142 | {"fortezza_rc4_128_sha" , SSL_FORTEZZA_DMS_WITH_RC4_128_SHA}, |
143 | {"fortezza_null" , SSL_FORTEZZA_DMS_WITH_NULL_SHA}, |
144 | /* TLS 1.0: Exportable 56-bit Cipher Suites. */ |
145 | {"rsa_des_56_sha" , TLS_RSA_EXPORT1024_WITH_DES_CBC_SHA}, |
146 | {"rsa_rc4_56_sha" , TLS_RSA_EXPORT1024_WITH_RC4_56_SHA}, |
147 | /* AES ciphers. */ |
148 | {"dhe_dss_aes_128_cbc_sha" , TLS_DHE_DSS_WITH_AES_128_CBC_SHA}, |
149 | {"dhe_dss_aes_256_cbc_sha" , TLS_DHE_DSS_WITH_AES_256_CBC_SHA}, |
150 | {"dhe_rsa_aes_128_cbc_sha" , TLS_DHE_RSA_WITH_AES_128_CBC_SHA}, |
151 | {"dhe_rsa_aes_256_cbc_sha" , TLS_DHE_RSA_WITH_AES_256_CBC_SHA}, |
152 | {"rsa_aes_128_sha" , TLS_RSA_WITH_AES_128_CBC_SHA}, |
153 | {"rsa_aes_256_sha" , TLS_RSA_WITH_AES_256_CBC_SHA}, |
154 | /* ECC ciphers. */ |
155 | {"ecdh_ecdsa_null_sha" , TLS_ECDH_ECDSA_WITH_NULL_SHA}, |
156 | {"ecdh_ecdsa_rc4_128_sha" , TLS_ECDH_ECDSA_WITH_RC4_128_SHA}, |
157 | {"ecdh_ecdsa_3des_sha" , TLS_ECDH_ECDSA_WITH_3DES_EDE_CBC_SHA}, |
158 | {"ecdh_ecdsa_aes_128_sha" , TLS_ECDH_ECDSA_WITH_AES_128_CBC_SHA}, |
159 | {"ecdh_ecdsa_aes_256_sha" , TLS_ECDH_ECDSA_WITH_AES_256_CBC_SHA}, |
160 | {"ecdhe_ecdsa_null_sha" , TLS_ECDHE_ECDSA_WITH_NULL_SHA}, |
161 | {"ecdhe_ecdsa_rc4_128_sha" , TLS_ECDHE_ECDSA_WITH_RC4_128_SHA}, |
162 | {"ecdhe_ecdsa_3des_sha" , TLS_ECDHE_ECDSA_WITH_3DES_EDE_CBC_SHA}, |
163 | {"ecdhe_ecdsa_aes_128_sha" , TLS_ECDHE_ECDSA_WITH_AES_128_CBC_SHA}, |
164 | {"ecdhe_ecdsa_aes_256_sha" , TLS_ECDHE_ECDSA_WITH_AES_256_CBC_SHA}, |
165 | {"ecdh_rsa_null_sha" , TLS_ECDH_RSA_WITH_NULL_SHA}, |
166 | {"ecdh_rsa_128_sha" , TLS_ECDH_RSA_WITH_RC4_128_SHA}, |
167 | {"ecdh_rsa_3des_sha" , TLS_ECDH_RSA_WITH_3DES_EDE_CBC_SHA}, |
168 | {"ecdh_rsa_aes_128_sha" , TLS_ECDH_RSA_WITH_AES_128_CBC_SHA}, |
169 | {"ecdh_rsa_aes_256_sha" , TLS_ECDH_RSA_WITH_AES_256_CBC_SHA}, |
170 | {"ecdhe_rsa_null" , TLS_ECDHE_RSA_WITH_NULL_SHA}, |
171 | {"ecdhe_rsa_rc4_128_sha" , TLS_ECDHE_RSA_WITH_RC4_128_SHA}, |
172 | {"ecdhe_rsa_3des_sha" , TLS_ECDHE_RSA_WITH_3DES_EDE_CBC_SHA}, |
173 | {"ecdhe_rsa_aes_128_sha" , TLS_ECDHE_RSA_WITH_AES_128_CBC_SHA}, |
174 | {"ecdhe_rsa_aes_256_sha" , TLS_ECDHE_RSA_WITH_AES_256_CBC_SHA}, |
175 | {"ecdh_anon_null_sha" , TLS_ECDH_anon_WITH_NULL_SHA}, |
176 | {"ecdh_anon_rc4_128sha" , TLS_ECDH_anon_WITH_RC4_128_SHA}, |
177 | {"ecdh_anon_3des_sha" , TLS_ECDH_anon_WITH_3DES_EDE_CBC_SHA}, |
178 | {"ecdh_anon_aes_128_sha" , TLS_ECDH_anon_WITH_AES_128_CBC_SHA}, |
179 | {"ecdh_anon_aes_256_sha" , TLS_ECDH_anon_WITH_AES_256_CBC_SHA}, |
180 | #ifdef TLS_RSA_WITH_NULL_SHA256 |
181 | /* new HMAC-SHA256 cipher suites specified in RFC */ |
182 | {"rsa_null_sha_256" , TLS_RSA_WITH_NULL_SHA256}, |
183 | {"rsa_aes_128_cbc_sha_256" , TLS_RSA_WITH_AES_128_CBC_SHA256}, |
184 | {"rsa_aes_256_cbc_sha_256" , TLS_RSA_WITH_AES_256_CBC_SHA256}, |
185 | {"dhe_rsa_aes_128_cbc_sha_256" , TLS_DHE_RSA_WITH_AES_128_CBC_SHA256}, |
186 | {"dhe_rsa_aes_256_cbc_sha_256" , TLS_DHE_RSA_WITH_AES_256_CBC_SHA256}, |
187 | {"ecdhe_ecdsa_aes_128_cbc_sha_256" , TLS_ECDHE_ECDSA_WITH_AES_128_CBC_SHA256}, |
188 | {"ecdhe_rsa_aes_128_cbc_sha_256" , TLS_ECDHE_RSA_WITH_AES_128_CBC_SHA256}, |
189 | #endif |
190 | #ifdef TLS_RSA_WITH_AES_128_GCM_SHA256 |
191 | /* AES GCM cipher suites in RFC 5288 and RFC 5289 */ |
192 | {"rsa_aes_128_gcm_sha_256" , TLS_RSA_WITH_AES_128_GCM_SHA256}, |
193 | {"dhe_rsa_aes_128_gcm_sha_256" , TLS_DHE_RSA_WITH_AES_128_GCM_SHA256}, |
194 | {"dhe_dss_aes_128_gcm_sha_256" , TLS_DHE_DSS_WITH_AES_128_GCM_SHA256}, |
195 | {"ecdhe_ecdsa_aes_128_gcm_sha_256" , TLS_ECDHE_ECDSA_WITH_AES_128_GCM_SHA256}, |
196 | {"ecdh_ecdsa_aes_128_gcm_sha_256" , TLS_ECDH_ECDSA_WITH_AES_128_GCM_SHA256}, |
197 | {"ecdhe_rsa_aes_128_gcm_sha_256" , TLS_ECDHE_RSA_WITH_AES_128_GCM_SHA256}, |
198 | {"ecdh_rsa_aes_128_gcm_sha_256" , TLS_ECDH_RSA_WITH_AES_128_GCM_SHA256}, |
199 | #endif |
200 | #ifdef TLS_ECDHE_RSA_WITH_AES_256_GCM_SHA384 |
201 | /* cipher suites using SHA384 */ |
202 | {"rsa_aes_256_gcm_sha_384" , TLS_RSA_WITH_AES_256_GCM_SHA384}, |
203 | {"dhe_rsa_aes_256_gcm_sha_384" , TLS_DHE_RSA_WITH_AES_256_GCM_SHA384}, |
204 | {"dhe_dss_aes_256_gcm_sha_384" , TLS_DHE_DSS_WITH_AES_256_GCM_SHA384}, |
205 | {"ecdhe_ecdsa_aes_256_sha_384" , TLS_ECDHE_ECDSA_WITH_AES_256_CBC_SHA384}, |
206 | {"ecdhe_rsa_aes_256_sha_384" , TLS_ECDHE_RSA_WITH_AES_256_CBC_SHA384}, |
207 | {"ecdhe_ecdsa_aes_256_gcm_sha_384" , TLS_ECDHE_ECDSA_WITH_AES_256_GCM_SHA384}, |
208 | {"ecdhe_rsa_aes_256_gcm_sha_384" , TLS_ECDHE_RSA_WITH_AES_256_GCM_SHA384}, |
209 | #endif |
210 | #ifdef TLS_DHE_RSA_WITH_CHACHA20_POLY1305_SHA256 |
211 | /* chacha20-poly1305 cipher suites */ |
212 | {"ecdhe_rsa_chacha20_poly1305_sha_256" , |
213 | TLS_ECDHE_RSA_WITH_CHACHA20_POLY1305_SHA256}, |
214 | {"ecdhe_ecdsa_chacha20_poly1305_sha_256" , |
215 | TLS_ECDHE_ECDSA_WITH_CHACHA20_POLY1305_SHA256}, |
216 | {"dhe_rsa_chacha20_poly1305_sha_256" , |
217 | TLS_DHE_RSA_WITH_CHACHA20_POLY1305_SHA256}, |
218 | #endif |
219 | #ifdef TLS_AES_256_GCM_SHA384 |
220 | {"aes_128_gcm_sha_256" , TLS_AES_128_GCM_SHA256}, |
221 | {"aes_256_gcm_sha_384" , TLS_AES_256_GCM_SHA384}, |
222 | {"chacha20_poly1305_sha_256" , TLS_CHACHA20_POLY1305_SHA256}, |
223 | #endif |
224 | }; |
225 | |
226 | #if defined(WIN32) |
227 | static const char *pem_library = "nsspem.dll" ; |
228 | static const char *trust_library = "nssckbi.dll" ; |
229 | #elif defined(__APPLE__) |
230 | static const char *pem_library = "libnsspem.dylib" ; |
231 | static const char *trust_library = "libnssckbi.dylib" ; |
232 | #else |
233 | static const char *pem_library = "libnsspem.so" ; |
234 | static const char *trust_library = "libnssckbi.so" ; |
235 | #endif |
236 | |
237 | static SECMODModule *pem_module = NULL; |
238 | static SECMODModule *trust_module = NULL; |
239 | |
240 | /* NSPR I/O layer we use to detect blocking direction during SSL handshake */ |
241 | static PRDescIdentity nspr_io_identity = PR_INVALID_IO_LAYER; |
242 | static PRIOMethods nspr_io_methods; |
243 | |
244 | static const char *nss_error_to_name(PRErrorCode code) |
245 | { |
246 | const char *name = PR_ErrorToName(code); |
247 | if(name) |
248 | return name; |
249 | |
250 | return "unknown error" ; |
251 | } |
252 | |
253 | static void nss_print_error_message(struct Curl_easy *data, PRUint32 err) |
254 | { |
255 | failf(data, "%s" , PR_ErrorToString(err, PR_LANGUAGE_I_DEFAULT)); |
256 | } |
257 | |
258 | static char *nss_sslver_to_name(PRUint16 nssver) |
259 | { |
260 | switch(nssver) { |
261 | case SSL_LIBRARY_VERSION_2: |
262 | return strdup("SSLv2" ); |
263 | case SSL_LIBRARY_VERSION_3_0: |
264 | return strdup("SSLv3" ); |
265 | case SSL_LIBRARY_VERSION_TLS_1_0: |
266 | return strdup("TLSv1.0" ); |
267 | #ifdef SSL_LIBRARY_VERSION_TLS_1_1 |
268 | case SSL_LIBRARY_VERSION_TLS_1_1: |
269 | return strdup("TLSv1.1" ); |
270 | #endif |
271 | #ifdef SSL_LIBRARY_VERSION_TLS_1_2 |
272 | case SSL_LIBRARY_VERSION_TLS_1_2: |
273 | return strdup("TLSv1.2" ); |
274 | #endif |
275 | #ifdef SSL_LIBRARY_VERSION_TLS_1_3 |
276 | case SSL_LIBRARY_VERSION_TLS_1_3: |
277 | return strdup("TLSv1.3" ); |
278 | #endif |
279 | default: |
280 | return curl_maprintf("0x%04x" , nssver); |
281 | } |
282 | } |
283 | |
284 | static SECStatus set_ciphers(struct Curl_easy *data, PRFileDesc * model, |
285 | char *cipher_list) |
286 | { |
287 | unsigned int i; |
288 | PRBool cipher_state[NUM_OF_CIPHERS]; |
289 | PRBool found; |
290 | char *cipher; |
291 | |
292 | /* use accessors to avoid dynamic linking issues after an update of NSS */ |
293 | const PRUint16 num_implemented_ciphers = SSL_GetNumImplementedCiphers(); |
294 | const PRUint16 *implemented_ciphers = SSL_GetImplementedCiphers(); |
295 | if(!implemented_ciphers) |
296 | return SECFailure; |
297 | |
298 | /* First disable all ciphers. This uses a different max value in case |
299 | * NSS adds more ciphers later we don't want them available by |
300 | * accident |
301 | */ |
302 | for(i = 0; i < num_implemented_ciphers; i++) { |
303 | SSL_CipherPrefSet(model, implemented_ciphers[i], PR_FALSE); |
304 | } |
305 | |
306 | /* Set every entry in our list to false */ |
307 | for(i = 0; i < NUM_OF_CIPHERS; i++) { |
308 | cipher_state[i] = PR_FALSE; |
309 | } |
310 | |
311 | cipher = cipher_list; |
312 | |
313 | while(cipher_list && (cipher_list[0])) { |
314 | while((*cipher) && (ISSPACE(*cipher))) |
315 | ++cipher; |
316 | |
317 | cipher_list = strchr(cipher, ','); |
318 | if(cipher_list) { |
319 | *cipher_list++ = '\0'; |
320 | } |
321 | |
322 | found = PR_FALSE; |
323 | |
324 | for(i = 0; i<NUM_OF_CIPHERS; i++) { |
325 | if(strcasecompare(cipher, cipherlist[i].name)) { |
326 | cipher_state[i] = PR_TRUE; |
327 | found = PR_TRUE; |
328 | break; |
329 | } |
330 | } |
331 | |
332 | if(found == PR_FALSE) { |
333 | failf(data, "Unknown cipher in list: %s" , cipher); |
334 | return SECFailure; |
335 | } |
336 | |
337 | if(cipher_list) { |
338 | cipher = cipher_list; |
339 | } |
340 | } |
341 | |
342 | /* Finally actually enable the selected ciphers */ |
343 | for(i = 0; i<NUM_OF_CIPHERS; i++) { |
344 | if(!cipher_state[i]) |
345 | continue; |
346 | |
347 | if(SSL_CipherPrefSet(model, cipherlist[i].num, PR_TRUE) != SECSuccess) { |
348 | failf(data, "cipher-suite not supported by NSS: %s" , cipherlist[i].name); |
349 | return SECFailure; |
350 | } |
351 | } |
352 | |
353 | return SECSuccess; |
354 | } |
355 | |
356 | /* |
357 | * Return true if at least one cipher-suite is enabled. Used to determine |
358 | * if we need to call NSS_SetDomesticPolicy() to enable the default ciphers. |
359 | */ |
360 | static bool any_cipher_enabled(void) |
361 | { |
362 | unsigned int i; |
363 | |
364 | for(i = 0; i<NUM_OF_CIPHERS; i++) { |
365 | PRInt32 policy = 0; |
366 | SSL_CipherPolicyGet(cipherlist[i].num, &policy); |
367 | if(policy) |
368 | return TRUE; |
369 | } |
370 | |
371 | return FALSE; |
372 | } |
373 | |
374 | /* |
375 | * Determine whether the nickname passed in is a filename that needs to |
376 | * be loaded as a PEM or a regular NSS nickname. |
377 | * |
378 | * returns 1 for a file |
379 | * returns 0 for not a file (NSS nickname) |
380 | */ |
381 | static int is_file(const char *filename) |
382 | { |
383 | struct_stat st; |
384 | |
385 | if(filename == NULL) |
386 | return 0; |
387 | |
388 | if(stat(filename, &st) == 0) |
389 | if(S_ISREG(st.st_mode) || S_ISFIFO(st.st_mode) || S_ISCHR(st.st_mode)) |
390 | return 1; |
391 | |
392 | return 0; |
393 | } |
394 | |
395 | /* Check if the given string is filename or nickname of a certificate. If the |
396 | * given string is recognized as filename, return NULL. If the given string is |
397 | * recognized as nickname, return a duplicated string. The returned string |
398 | * should be later deallocated using free(). If the OOM failure occurs, we |
399 | * return NULL, too. |
400 | */ |
401 | static char *dup_nickname(struct Curl_easy *data, const char *str) |
402 | { |
403 | const char *n; |
404 | |
405 | if(!is_file(str)) |
406 | /* no such file exists, use the string as nickname */ |
407 | return strdup(str); |
408 | |
409 | /* search the first slash; we require at least one slash in a file name */ |
410 | n = strchr(str, '/'); |
411 | if(!n) { |
412 | infof(data, "warning: certificate file name \"%s\" handled as nickname; " |
413 | "please use \"./%s\" to force file name\n" , str, str); |
414 | return strdup(str); |
415 | } |
416 | |
417 | /* we'll use the PEM reader to read the certificate from file */ |
418 | return NULL; |
419 | } |
420 | |
421 | /* Lock/unlock wrapper for PK11_FindSlotByName() to work around race condition |
422 | * in nssSlot_IsTokenPresent() causing spurious SEC_ERROR_NO_TOKEN. For more |
423 | * details, go to <https://bugzilla.mozilla.org/1297397>. |
424 | */ |
425 | static PK11SlotInfo* nss_find_slot_by_name(const char *slot_name) |
426 | { |
427 | PK11SlotInfo *slot; |
428 | PR_Lock(nss_findslot_lock); |
429 | slot = PK11_FindSlotByName(slot_name); |
430 | PR_Unlock(nss_findslot_lock); |
431 | return slot; |
432 | } |
433 | |
434 | /* wrap 'ptr' as list node and tail-insert into 'list' */ |
435 | static CURLcode insert_wrapped_ptr(struct curl_llist *list, void *ptr) |
436 | { |
437 | struct ptr_list_wrap *wrap = malloc(sizeof(*wrap)); |
438 | if(!wrap) |
439 | return CURLE_OUT_OF_MEMORY; |
440 | |
441 | wrap->ptr = ptr; |
442 | Curl_llist_insert_next(list, list->tail, wrap, &wrap->node); |
443 | return CURLE_OK; |
444 | } |
445 | |
446 | /* Call PK11_CreateGenericObject() with the given obj_class and filename. If |
447 | * the call succeeds, append the object handle to the list of objects so that |
448 | * the object can be destroyed in Curl_nss_close(). */ |
449 | static CURLcode nss_create_object(struct ssl_connect_data *connssl, |
450 | CK_OBJECT_CLASS obj_class, |
451 | const char *filename, bool cacert) |
452 | { |
453 | PK11SlotInfo *slot; |
454 | PK11GenericObject *obj; |
455 | CK_BBOOL cktrue = CK_TRUE; |
456 | CK_BBOOL ckfalse = CK_FALSE; |
457 | CK_ATTRIBUTE attrs[/* max count of attributes */ 4]; |
458 | int attr_cnt = 0; |
459 | CURLcode result = (cacert) |
460 | ? CURLE_SSL_CACERT_BADFILE |
461 | : CURLE_SSL_CERTPROBLEM; |
462 | |
463 | const int slot_id = (cacert) ? 0 : 1; |
464 | char *slot_name = aprintf("PEM Token #%d" , slot_id); |
465 | if(!slot_name) |
466 | return CURLE_OUT_OF_MEMORY; |
467 | |
468 | slot = nss_find_slot_by_name(slot_name); |
469 | free(slot_name); |
470 | if(!slot) |
471 | return result; |
472 | |
473 | PK11_SETATTRS(attrs, attr_cnt, CKA_CLASS, &obj_class, sizeof(obj_class)); |
474 | PK11_SETATTRS(attrs, attr_cnt, CKA_TOKEN, &cktrue, sizeof(CK_BBOOL)); |
475 | PK11_SETATTRS(attrs, attr_cnt, CKA_LABEL, (unsigned char *)filename, |
476 | (CK_ULONG)strlen(filename) + 1); |
477 | |
478 | if(CKO_CERTIFICATE == obj_class) { |
479 | CK_BBOOL *pval = (cacert) ? (&cktrue) : (&ckfalse); |
480 | PK11_SETATTRS(attrs, attr_cnt, CKA_TRUST, pval, sizeof(*pval)); |
481 | } |
482 | |
483 | /* PK11_CreateManagedGenericObject() was introduced in NSS 3.34 because |
484 | * PK11_DestroyGenericObject() does not release resources allocated by |
485 | * PK11_CreateGenericObject() early enough. */ |
486 | obj = |
487 | #ifdef HAVE_PK11_CREATEMANAGEDGENERICOBJECT |
488 | PK11_CreateManagedGenericObject |
489 | #else |
490 | PK11_CreateGenericObject |
491 | #endif |
492 | (slot, attrs, attr_cnt, PR_FALSE); |
493 | |
494 | PK11_FreeSlot(slot); |
495 | if(!obj) |
496 | return result; |
497 | |
498 | if(insert_wrapped_ptr(&BACKEND->obj_list, obj) != CURLE_OK) { |
499 | PK11_DestroyGenericObject(obj); |
500 | return CURLE_OUT_OF_MEMORY; |
501 | } |
502 | |
503 | if(!cacert && CKO_CERTIFICATE == obj_class) |
504 | /* store reference to a client certificate */ |
505 | BACKEND->obj_clicert = obj; |
506 | |
507 | return CURLE_OK; |
508 | } |
509 | |
510 | /* Destroy the NSS object whose handle is given by ptr. This function is |
511 | * a callback of Curl_llist_alloc() used by Curl_llist_destroy() to destroy |
512 | * NSS objects in Curl_nss_close() */ |
513 | static void nss_destroy_object(void *user, void *ptr) |
514 | { |
515 | struct ptr_list_wrap *wrap = (struct ptr_list_wrap *) ptr; |
516 | PK11GenericObject *obj = (PK11GenericObject *) wrap->ptr; |
517 | (void) user; |
518 | PK11_DestroyGenericObject(obj); |
519 | free(wrap); |
520 | } |
521 | |
522 | /* same as nss_destroy_object() but for CRL items */ |
523 | static void nss_destroy_crl_item(void *user, void *ptr) |
524 | { |
525 | struct ptr_list_wrap *wrap = (struct ptr_list_wrap *) ptr; |
526 | SECItem *crl_der = (SECItem *) wrap->ptr; |
527 | (void) user; |
528 | SECITEM_FreeItem(crl_der, PR_TRUE); |
529 | free(wrap); |
530 | } |
531 | |
532 | static CURLcode nss_load_cert(struct ssl_connect_data *ssl, |
533 | const char *filename, PRBool cacert) |
534 | { |
535 | CURLcode result = (cacert) |
536 | ? CURLE_SSL_CACERT_BADFILE |
537 | : CURLE_SSL_CERTPROBLEM; |
538 | |
539 | /* libnsspem.so leaks memory if the requested file does not exist. For more |
540 | * details, go to <https://bugzilla.redhat.com/734760>. */ |
541 | if(is_file(filename)) |
542 | result = nss_create_object(ssl, CKO_CERTIFICATE, filename, cacert); |
543 | |
544 | if(!result && !cacert) { |
545 | /* we have successfully loaded a client certificate */ |
546 | CERTCertificate *cert; |
547 | char *nickname = NULL; |
548 | char *n = strrchr(filename, '/'); |
549 | if(n) |
550 | n++; |
551 | |
552 | /* The following undocumented magic helps to avoid a SIGSEGV on call |
553 | * of PK11_ReadRawAttribute() from SelectClientCert() when using an |
554 | * immature version of libnsspem.so. For more details, go to |
555 | * <https://bugzilla.redhat.com/733685>. */ |
556 | nickname = aprintf("PEM Token #1:%s" , n); |
557 | if(nickname) { |
558 | cert = PK11_FindCertFromNickname(nickname, NULL); |
559 | if(cert) |
560 | CERT_DestroyCertificate(cert); |
561 | |
562 | free(nickname); |
563 | } |
564 | } |
565 | |
566 | return result; |
567 | } |
568 | |
569 | /* add given CRL to cache if it is not already there */ |
570 | static CURLcode nss_cache_crl(SECItem *crl_der) |
571 | { |
572 | CERTCertDBHandle *db = CERT_GetDefaultCertDB(); |
573 | CERTSignedCrl *crl = SEC_FindCrlByDERCert(db, crl_der, 0); |
574 | if(crl) { |
575 | /* CRL already cached */ |
576 | SEC_DestroyCrl(crl); |
577 | SECITEM_FreeItem(crl_der, PR_TRUE); |
578 | return CURLE_OK; |
579 | } |
580 | |
581 | /* acquire lock before call of CERT_CacheCRL() and accessing nss_crl_list */ |
582 | PR_Lock(nss_crllock); |
583 | |
584 | if(SECSuccess != CERT_CacheCRL(db, crl_der)) { |
585 | /* unable to cache CRL */ |
586 | SECITEM_FreeItem(crl_der, PR_TRUE); |
587 | PR_Unlock(nss_crllock); |
588 | return CURLE_SSL_CRL_BADFILE; |
589 | } |
590 | |
591 | /* store the CRL item so that we can free it in Curl_nss_cleanup() */ |
592 | if(insert_wrapped_ptr(&nss_crl_list, crl_der) != CURLE_OK) { |
593 | if(SECSuccess == CERT_UncacheCRL(db, crl_der)) |
594 | SECITEM_FreeItem(crl_der, PR_TRUE); |
595 | PR_Unlock(nss_crllock); |
596 | return CURLE_OUT_OF_MEMORY; |
597 | } |
598 | |
599 | /* we need to clear session cache, so that the CRL could take effect */ |
600 | SSL_ClearSessionCache(); |
601 | PR_Unlock(nss_crllock); |
602 | return CURLE_OK; |
603 | } |
604 | |
605 | static CURLcode nss_load_crl(const char *crlfilename) |
606 | { |
607 | PRFileDesc *infile; |
608 | PRFileInfo info; |
609 | SECItem filedata = { 0, NULL, 0 }; |
610 | SECItem *crl_der = NULL; |
611 | char *body; |
612 | |
613 | infile = PR_Open(crlfilename, PR_RDONLY, 0); |
614 | if(!infile) |
615 | return CURLE_SSL_CRL_BADFILE; |
616 | |
617 | if(PR_SUCCESS != PR_GetOpenFileInfo(infile, &info)) |
618 | goto fail; |
619 | |
620 | if(!SECITEM_AllocItem(NULL, &filedata, info.size + /* zero ended */ 1)) |
621 | goto fail; |
622 | |
623 | if(info.size != PR_Read(infile, filedata.data, info.size)) |
624 | goto fail; |
625 | |
626 | crl_der = SECITEM_AllocItem(NULL, NULL, 0U); |
627 | if(!crl_der) |
628 | goto fail; |
629 | |
630 | /* place a trailing zero right after the visible data */ |
631 | body = (char *)filedata.data; |
632 | body[--filedata.len] = '\0'; |
633 | |
634 | body = strstr(body, "-----BEGIN" ); |
635 | if(body) { |
636 | /* assume ASCII */ |
637 | char *trailer; |
638 | char *begin = PORT_Strchr(body, '\n'); |
639 | if(!begin) |
640 | begin = PORT_Strchr(body, '\r'); |
641 | if(!begin) |
642 | goto fail; |
643 | |
644 | trailer = strstr(++begin, "-----END" ); |
645 | if(!trailer) |
646 | goto fail; |
647 | |
648 | /* retrieve DER from ASCII */ |
649 | *trailer = '\0'; |
650 | if(ATOB_ConvertAsciiToItem(crl_der, begin)) |
651 | goto fail; |
652 | |
653 | SECITEM_FreeItem(&filedata, PR_FALSE); |
654 | } |
655 | else |
656 | /* assume DER */ |
657 | *crl_der = filedata; |
658 | |
659 | PR_Close(infile); |
660 | return nss_cache_crl(crl_der); |
661 | |
662 | fail: |
663 | PR_Close(infile); |
664 | SECITEM_FreeItem(crl_der, PR_TRUE); |
665 | SECITEM_FreeItem(&filedata, PR_FALSE); |
666 | return CURLE_SSL_CRL_BADFILE; |
667 | } |
668 | |
669 | static CURLcode nss_load_key(struct connectdata *conn, int sockindex, |
670 | char *key_file) |
671 | { |
672 | PK11SlotInfo *slot, *tmp; |
673 | SECStatus status; |
674 | CURLcode result; |
675 | struct ssl_connect_data *ssl = conn->ssl; |
676 | struct Curl_easy *data = conn->data; |
677 | |
678 | (void)sockindex; /* unused */ |
679 | |
680 | result = nss_create_object(ssl, CKO_PRIVATE_KEY, key_file, FALSE); |
681 | if(result) { |
682 | PR_SetError(SEC_ERROR_BAD_KEY, 0); |
683 | return result; |
684 | } |
685 | |
686 | slot = nss_find_slot_by_name("PEM Token #1" ); |
687 | if(!slot) |
688 | return CURLE_SSL_CERTPROBLEM; |
689 | |
690 | /* This will force the token to be seen as re-inserted */ |
691 | tmp = SECMOD_WaitForAnyTokenEvent(pem_module, 0, 0); |
692 | if(tmp) |
693 | PK11_FreeSlot(tmp); |
694 | if(!PK11_IsPresent(slot)) { |
695 | PK11_FreeSlot(slot); |
696 | return CURLE_SSL_CERTPROBLEM; |
697 | } |
698 | |
699 | status = PK11_Authenticate(slot, PR_TRUE, SSL_SET_OPTION(key_passwd)); |
700 | PK11_FreeSlot(slot); |
701 | |
702 | return (SECSuccess == status) ? CURLE_OK : CURLE_SSL_CERTPROBLEM; |
703 | } |
704 | |
705 | static int display_error(struct connectdata *conn, PRInt32 err, |
706 | const char *filename) |
707 | { |
708 | switch(err) { |
709 | case SEC_ERROR_BAD_PASSWORD: |
710 | failf(conn->data, "Unable to load client key: Incorrect password" ); |
711 | return 1; |
712 | case SEC_ERROR_UNKNOWN_CERT: |
713 | failf(conn->data, "Unable to load certificate %s" , filename); |
714 | return 1; |
715 | default: |
716 | break; |
717 | } |
718 | return 0; /* The caller will print a generic error */ |
719 | } |
720 | |
721 | static CURLcode cert_stuff(struct connectdata *conn, int sockindex, |
722 | char *cert_file, char *key_file) |
723 | { |
724 | struct Curl_easy *data = conn->data; |
725 | CURLcode result; |
726 | |
727 | if(cert_file) { |
728 | result = nss_load_cert(&conn->ssl[sockindex], cert_file, PR_FALSE); |
729 | if(result) { |
730 | const PRErrorCode err = PR_GetError(); |
731 | if(!display_error(conn, err, cert_file)) { |
732 | const char *err_name = nss_error_to_name(err); |
733 | failf(data, "unable to load client cert: %d (%s)" , err, err_name); |
734 | } |
735 | |
736 | return result; |
737 | } |
738 | } |
739 | |
740 | if(key_file || (is_file(cert_file))) { |
741 | if(key_file) |
742 | result = nss_load_key(conn, sockindex, key_file); |
743 | else |
744 | /* In case the cert file also has the key */ |
745 | result = nss_load_key(conn, sockindex, cert_file); |
746 | if(result) { |
747 | const PRErrorCode err = PR_GetError(); |
748 | if(!display_error(conn, err, key_file)) { |
749 | const char *err_name = nss_error_to_name(err); |
750 | failf(data, "unable to load client key: %d (%s)" , err, err_name); |
751 | } |
752 | |
753 | return result; |
754 | } |
755 | } |
756 | |
757 | return CURLE_OK; |
758 | } |
759 | |
760 | static char *nss_get_password(PK11SlotInfo *slot, PRBool retry, void *arg) |
761 | { |
762 | (void)slot; /* unused */ |
763 | |
764 | if(retry || NULL == arg) |
765 | return NULL; |
766 | else |
767 | return (char *)PORT_Strdup((char *)arg); |
768 | } |
769 | |
770 | /* bypass the default SSL_AuthCertificate() hook in case we do not want to |
771 | * verify peer */ |
772 | static SECStatus nss_auth_cert_hook(void *arg, PRFileDesc *fd, PRBool checksig, |
773 | PRBool isServer) |
774 | { |
775 | struct connectdata *conn = (struct connectdata *)arg; |
776 | |
777 | #ifdef SSL_ENABLE_OCSP_STAPLING |
778 | if(SSL_CONN_CONFIG(verifystatus)) { |
779 | SECStatus cacheResult; |
780 | |
781 | const SECItemArray *csa = SSL_PeerStapledOCSPResponses(fd); |
782 | if(!csa) { |
783 | failf(conn->data, "Invalid OCSP response" ); |
784 | return SECFailure; |
785 | } |
786 | |
787 | if(csa->len == 0) { |
788 | failf(conn->data, "No OCSP response received" ); |
789 | return SECFailure; |
790 | } |
791 | |
792 | cacheResult = CERT_CacheOCSPResponseFromSideChannel( |
793 | CERT_GetDefaultCertDB(), SSL_PeerCertificate(fd), |
794 | PR_Now(), &csa->items[0], arg |
795 | ); |
796 | |
797 | if(cacheResult != SECSuccess) { |
798 | failf(conn->data, "Invalid OCSP response" ); |
799 | return cacheResult; |
800 | } |
801 | } |
802 | #endif |
803 | |
804 | if(!SSL_CONN_CONFIG(verifypeer)) { |
805 | infof(conn->data, "skipping SSL peer certificate verification\n" ); |
806 | return SECSuccess; |
807 | } |
808 | |
809 | return SSL_AuthCertificate(CERT_GetDefaultCertDB(), fd, checksig, isServer); |
810 | } |
811 | |
812 | /** |
813 | * Inform the application that the handshake is complete. |
814 | */ |
815 | static void HandshakeCallback(PRFileDesc *sock, void *arg) |
816 | { |
817 | struct connectdata *conn = (struct connectdata*) arg; |
818 | unsigned int buflenmax = 50; |
819 | unsigned char buf[50]; |
820 | unsigned int buflen; |
821 | SSLNextProtoState state; |
822 | |
823 | if(!conn->bits.tls_enable_npn && !conn->bits.tls_enable_alpn) { |
824 | return; |
825 | } |
826 | |
827 | if(SSL_GetNextProto(sock, &state, buf, &buflen, buflenmax) == SECSuccess) { |
828 | |
829 | switch(state) { |
830 | #if NSSVERNUM >= 0x031a00 /* 3.26.0 */ |
831 | /* used by NSS internally to implement 0-RTT */ |
832 | case SSL_NEXT_PROTO_EARLY_VALUE: |
833 | /* fall through! */ |
834 | #endif |
835 | case SSL_NEXT_PROTO_NO_SUPPORT: |
836 | case SSL_NEXT_PROTO_NO_OVERLAP: |
837 | infof(conn->data, "ALPN/NPN, server did not agree to a protocol\n" ); |
838 | return; |
839 | #ifdef SSL_ENABLE_ALPN |
840 | case SSL_NEXT_PROTO_SELECTED: |
841 | infof(conn->data, "ALPN, server accepted to use %.*s\n" , buflen, buf); |
842 | break; |
843 | #endif |
844 | case SSL_NEXT_PROTO_NEGOTIATED: |
845 | infof(conn->data, "NPN, server accepted to use %.*s\n" , buflen, buf); |
846 | break; |
847 | } |
848 | |
849 | #ifdef USE_NGHTTP2 |
850 | if(buflen == NGHTTP2_PROTO_VERSION_ID_LEN && |
851 | !memcmp(NGHTTP2_PROTO_VERSION_ID, buf, NGHTTP2_PROTO_VERSION_ID_LEN)) { |
852 | conn->negnpn = CURL_HTTP_VERSION_2; |
853 | } |
854 | else |
855 | #endif |
856 | if(buflen == ALPN_HTTP_1_1_LENGTH && |
857 | !memcmp(ALPN_HTTP_1_1, buf, ALPN_HTTP_1_1_LENGTH)) { |
858 | conn->negnpn = CURL_HTTP_VERSION_1_1; |
859 | } |
860 | Curl_multiuse_state(conn, conn->negnpn == CURL_HTTP_VERSION_2 ? |
861 | BUNDLE_MULTIPLEX : BUNDLE_NO_MULTIUSE); |
862 | } |
863 | } |
864 | |
865 | #if NSSVERNUM >= 0x030f04 /* 3.15.4 */ |
866 | static SECStatus CanFalseStartCallback(PRFileDesc *sock, void *client_data, |
867 | PRBool *canFalseStart) |
868 | { |
869 | struct connectdata *conn = client_data; |
870 | struct Curl_easy *data = conn->data; |
871 | |
872 | SSLChannelInfo channelInfo; |
873 | SSLCipherSuiteInfo cipherInfo; |
874 | |
875 | SECStatus rv; |
876 | PRBool negotiatedExtension; |
877 | |
878 | *canFalseStart = PR_FALSE; |
879 | |
880 | if(SSL_GetChannelInfo(sock, &channelInfo, sizeof(channelInfo)) != SECSuccess) |
881 | return SECFailure; |
882 | |
883 | if(SSL_GetCipherSuiteInfo(channelInfo.cipherSuite, &cipherInfo, |
884 | sizeof(cipherInfo)) != SECSuccess) |
885 | return SECFailure; |
886 | |
887 | /* Prevent version downgrade attacks from TLS 1.2, and avoid False Start for |
888 | * TLS 1.3 and later. See https://bugzilla.mozilla.org/show_bug.cgi?id=861310 |
889 | */ |
890 | if(channelInfo.protocolVersion != SSL_LIBRARY_VERSION_TLS_1_2) |
891 | goto end; |
892 | |
893 | /* Only allow ECDHE key exchange algorithm. |
894 | * See https://bugzilla.mozilla.org/show_bug.cgi?id=952863 */ |
895 | if(cipherInfo.keaType != ssl_kea_ecdh) |
896 | goto end; |
897 | |
898 | /* Prevent downgrade attacks on the symmetric cipher. We do not allow CBC |
899 | * mode due to BEAST, POODLE, and other attacks on the MAC-then-Encrypt |
900 | * design. See https://bugzilla.mozilla.org/show_bug.cgi?id=1109766 */ |
901 | if(cipherInfo.symCipher != ssl_calg_aes_gcm) |
902 | goto end; |
903 | |
904 | /* Enforce ALPN or NPN to do False Start, as an indicator of server |
905 | * compatibility. */ |
906 | rv = SSL_HandshakeNegotiatedExtension(sock, ssl_app_layer_protocol_xtn, |
907 | &negotiatedExtension); |
908 | if(rv != SECSuccess || !negotiatedExtension) { |
909 | rv = SSL_HandshakeNegotiatedExtension(sock, ssl_next_proto_nego_xtn, |
910 | &negotiatedExtension); |
911 | } |
912 | |
913 | if(rv != SECSuccess || !negotiatedExtension) |
914 | goto end; |
915 | |
916 | *canFalseStart = PR_TRUE; |
917 | |
918 | infof(data, "Trying TLS False Start\n" ); |
919 | |
920 | end: |
921 | return SECSuccess; |
922 | } |
923 | #endif |
924 | |
925 | static void display_cert_info(struct Curl_easy *data, |
926 | CERTCertificate *cert) |
927 | { |
928 | char *subject, *issuer, *common_name; |
929 | PRExplodedTime printableTime; |
930 | char timeString[256]; |
931 | PRTime notBefore, notAfter; |
932 | |
933 | subject = CERT_NameToAscii(&cert->subject); |
934 | issuer = CERT_NameToAscii(&cert->issuer); |
935 | common_name = CERT_GetCommonName(&cert->subject); |
936 | infof(data, "\tsubject: %s\n" , subject); |
937 | |
938 | CERT_GetCertTimes(cert, ¬Before, ¬After); |
939 | PR_ExplodeTime(notBefore, PR_GMTParameters, &printableTime); |
940 | PR_FormatTime(timeString, 256, "%b %d %H:%M:%S %Y GMT" , &printableTime); |
941 | infof(data, "\tstart date: %s\n" , timeString); |
942 | PR_ExplodeTime(notAfter, PR_GMTParameters, &printableTime); |
943 | PR_FormatTime(timeString, 256, "%b %d %H:%M:%S %Y GMT" , &printableTime); |
944 | infof(data, "\texpire date: %s\n" , timeString); |
945 | infof(data, "\tcommon name: %s\n" , common_name); |
946 | infof(data, "\tissuer: %s\n" , issuer); |
947 | |
948 | PR_Free(subject); |
949 | PR_Free(issuer); |
950 | PR_Free(common_name); |
951 | } |
952 | |
953 | static CURLcode display_conn_info(struct connectdata *conn, PRFileDesc *sock) |
954 | { |
955 | CURLcode result = CURLE_OK; |
956 | SSLChannelInfo channel; |
957 | SSLCipherSuiteInfo suite; |
958 | CERTCertificate *cert; |
959 | CERTCertificate *cert2; |
960 | CERTCertificate *cert3; |
961 | PRTime now; |
962 | int i; |
963 | |
964 | if(SSL_GetChannelInfo(sock, &channel, sizeof(channel)) == |
965 | SECSuccess && channel.length == sizeof(channel) && |
966 | channel.cipherSuite) { |
967 | if(SSL_GetCipherSuiteInfo(channel.cipherSuite, |
968 | &suite, sizeof(suite)) == SECSuccess) { |
969 | infof(conn->data, "SSL connection using %s\n" , suite.cipherSuiteName); |
970 | } |
971 | } |
972 | |
973 | cert = SSL_PeerCertificate(sock); |
974 | if(cert) { |
975 | infof(conn->data, "Server certificate:\n" ); |
976 | |
977 | if(!conn->data->set.ssl.certinfo) { |
978 | display_cert_info(conn->data, cert); |
979 | CERT_DestroyCertificate(cert); |
980 | } |
981 | else { |
982 | /* Count certificates in chain. */ |
983 | now = PR_Now(); |
984 | i = 1; |
985 | if(!cert->isRoot) { |
986 | cert2 = CERT_FindCertIssuer(cert, now, certUsageSSLCA); |
987 | while(cert2) { |
988 | i++; |
989 | if(cert2->isRoot) { |
990 | CERT_DestroyCertificate(cert2); |
991 | break; |
992 | } |
993 | cert3 = CERT_FindCertIssuer(cert2, now, certUsageSSLCA); |
994 | CERT_DestroyCertificate(cert2); |
995 | cert2 = cert3; |
996 | } |
997 | } |
998 | |
999 | result = Curl_ssl_init_certinfo(conn->data, i); |
1000 | if(!result) { |
1001 | for(i = 0; cert; cert = cert2) { |
1002 | result = Curl_extract_certinfo(conn, i++, (char *)cert->derCert.data, |
1003 | (char *)cert->derCert.data + |
1004 | cert->derCert.len); |
1005 | if(result) |
1006 | break; |
1007 | |
1008 | if(cert->isRoot) { |
1009 | CERT_DestroyCertificate(cert); |
1010 | break; |
1011 | } |
1012 | |
1013 | cert2 = CERT_FindCertIssuer(cert, now, certUsageSSLCA); |
1014 | CERT_DestroyCertificate(cert); |
1015 | } |
1016 | } |
1017 | } |
1018 | } |
1019 | |
1020 | return result; |
1021 | } |
1022 | |
1023 | static SECStatus BadCertHandler(void *arg, PRFileDesc *sock) |
1024 | { |
1025 | struct connectdata *conn = (struct connectdata *)arg; |
1026 | struct Curl_easy *data = conn->data; |
1027 | PRErrorCode err = PR_GetError(); |
1028 | CERTCertificate *cert; |
1029 | |
1030 | /* remember the cert verification result */ |
1031 | if(SSL_IS_PROXY()) |
1032 | data->set.proxy_ssl.certverifyresult = err; |
1033 | else |
1034 | data->set.ssl.certverifyresult = err; |
1035 | |
1036 | if(err == SSL_ERROR_BAD_CERT_DOMAIN && !SSL_CONN_CONFIG(verifyhost)) |
1037 | /* we are asked not to verify the host name */ |
1038 | return SECSuccess; |
1039 | |
1040 | /* print only info about the cert, the error is printed off the callback */ |
1041 | cert = SSL_PeerCertificate(sock); |
1042 | if(cert) { |
1043 | infof(data, "Server certificate:\n" ); |
1044 | display_cert_info(data, cert); |
1045 | CERT_DestroyCertificate(cert); |
1046 | } |
1047 | |
1048 | return SECFailure; |
1049 | } |
1050 | |
1051 | /** |
1052 | * |
1053 | * Check that the Peer certificate's issuer certificate matches the one found |
1054 | * by issuer_nickname. This is not exactly the way OpenSSL and GNU TLS do the |
1055 | * issuer check, so we provide comments that mimic the OpenSSL |
1056 | * X509_check_issued function (in x509v3/v3_purp.c) |
1057 | */ |
1058 | static SECStatus check_issuer_cert(PRFileDesc *sock, |
1059 | char *issuer_nickname) |
1060 | { |
1061 | CERTCertificate *cert, *cert_issuer, *issuer; |
1062 | SECStatus res = SECSuccess; |
1063 | void *proto_win = NULL; |
1064 | |
1065 | cert = SSL_PeerCertificate(sock); |
1066 | cert_issuer = CERT_FindCertIssuer(cert, PR_Now(), certUsageObjectSigner); |
1067 | |
1068 | proto_win = SSL_RevealPinArg(sock); |
1069 | issuer = PK11_FindCertFromNickname(issuer_nickname, proto_win); |
1070 | |
1071 | if((!cert_issuer) || (!issuer)) |
1072 | res = SECFailure; |
1073 | else if(SECITEM_CompareItem(&cert_issuer->derCert, |
1074 | &issuer->derCert) != SECEqual) |
1075 | res = SECFailure; |
1076 | |
1077 | CERT_DestroyCertificate(cert); |
1078 | CERT_DestroyCertificate(issuer); |
1079 | CERT_DestroyCertificate(cert_issuer); |
1080 | return res; |
1081 | } |
1082 | |
1083 | static CURLcode cmp_peer_pubkey(struct ssl_connect_data *connssl, |
1084 | const char *pinnedpubkey) |
1085 | { |
1086 | CURLcode result = CURLE_SSL_PINNEDPUBKEYNOTMATCH; |
1087 | struct Curl_easy *data = BACKEND->data; |
1088 | CERTCertificate *cert; |
1089 | |
1090 | if(!pinnedpubkey) |
1091 | /* no pinned public key specified */ |
1092 | return CURLE_OK; |
1093 | |
1094 | /* get peer certificate */ |
1095 | cert = SSL_PeerCertificate(BACKEND->handle); |
1096 | if(cert) { |
1097 | /* extract public key from peer certificate */ |
1098 | SECKEYPublicKey *pubkey = CERT_ExtractPublicKey(cert); |
1099 | if(pubkey) { |
1100 | /* encode the public key as DER */ |
1101 | SECItem *cert_der = PK11_DEREncodePublicKey(pubkey); |
1102 | if(cert_der) { |
1103 | /* compare the public key with the pinned public key */ |
1104 | result = Curl_pin_peer_pubkey(data, pinnedpubkey, cert_der->data, |
1105 | cert_der->len); |
1106 | SECITEM_FreeItem(cert_der, PR_TRUE); |
1107 | } |
1108 | SECKEY_DestroyPublicKey(pubkey); |
1109 | } |
1110 | CERT_DestroyCertificate(cert); |
1111 | } |
1112 | |
1113 | /* report the resulting status */ |
1114 | switch(result) { |
1115 | case CURLE_OK: |
1116 | infof(data, "pinned public key verified successfully!\n" ); |
1117 | break; |
1118 | case CURLE_SSL_PINNEDPUBKEYNOTMATCH: |
1119 | failf(data, "failed to verify pinned public key" ); |
1120 | break; |
1121 | default: |
1122 | /* OOM, etc. */ |
1123 | break; |
1124 | } |
1125 | |
1126 | return result; |
1127 | } |
1128 | |
1129 | /** |
1130 | * |
1131 | * Callback to pick the SSL client certificate. |
1132 | */ |
1133 | static SECStatus SelectClientCert(void *arg, PRFileDesc *sock, |
1134 | struct CERTDistNamesStr *caNames, |
1135 | struct CERTCertificateStr **pRetCert, |
1136 | struct SECKEYPrivateKeyStr **pRetKey) |
1137 | { |
1138 | struct ssl_connect_data *connssl = (struct ssl_connect_data *)arg; |
1139 | struct Curl_easy *data = BACKEND->data; |
1140 | const char *nickname = BACKEND->client_nickname; |
1141 | static const char pem_slotname[] = "PEM Token #1" ; |
1142 | |
1143 | if(BACKEND->obj_clicert) { |
1144 | /* use the cert/key provided by PEM reader */ |
1145 | SECItem cert_der = { 0, NULL, 0 }; |
1146 | void *proto_win = SSL_RevealPinArg(sock); |
1147 | struct CERTCertificateStr *cert; |
1148 | struct SECKEYPrivateKeyStr *key; |
1149 | |
1150 | PK11SlotInfo *slot = nss_find_slot_by_name(pem_slotname); |
1151 | if(NULL == slot) { |
1152 | failf(data, "NSS: PK11 slot not found: %s" , pem_slotname); |
1153 | return SECFailure; |
1154 | } |
1155 | |
1156 | if(PK11_ReadRawAttribute(PK11_TypeGeneric, BACKEND->obj_clicert, CKA_VALUE, |
1157 | &cert_der) != SECSuccess) { |
1158 | failf(data, "NSS: CKA_VALUE not found in PK11 generic object" ); |
1159 | PK11_FreeSlot(slot); |
1160 | return SECFailure; |
1161 | } |
1162 | |
1163 | cert = PK11_FindCertFromDERCertItem(slot, &cert_der, proto_win); |
1164 | SECITEM_FreeItem(&cert_der, PR_FALSE); |
1165 | if(NULL == cert) { |
1166 | failf(data, "NSS: client certificate from file not found" ); |
1167 | PK11_FreeSlot(slot); |
1168 | return SECFailure; |
1169 | } |
1170 | |
1171 | key = PK11_FindPrivateKeyFromCert(slot, cert, NULL); |
1172 | PK11_FreeSlot(slot); |
1173 | if(NULL == key) { |
1174 | failf(data, "NSS: private key from file not found" ); |
1175 | CERT_DestroyCertificate(cert); |
1176 | return SECFailure; |
1177 | } |
1178 | |
1179 | infof(data, "NSS: client certificate from file\n" ); |
1180 | display_cert_info(data, cert); |
1181 | |
1182 | *pRetCert = cert; |
1183 | *pRetKey = key; |
1184 | return SECSuccess; |
1185 | } |
1186 | |
1187 | /* use the default NSS hook */ |
1188 | if(SECSuccess != NSS_GetClientAuthData((void *)nickname, sock, caNames, |
1189 | pRetCert, pRetKey) |
1190 | || NULL == *pRetCert) { |
1191 | |
1192 | if(NULL == nickname) |
1193 | failf(data, "NSS: client certificate not found (nickname not " |
1194 | "specified)" ); |
1195 | else |
1196 | failf(data, "NSS: client certificate not found: %s" , nickname); |
1197 | |
1198 | return SECFailure; |
1199 | } |
1200 | |
1201 | /* get certificate nickname if any */ |
1202 | nickname = (*pRetCert)->nickname; |
1203 | if(NULL == nickname) |
1204 | nickname = "[unknown]" ; |
1205 | |
1206 | if(!strncmp(nickname, pem_slotname, sizeof(pem_slotname) - 1U)) { |
1207 | failf(data, "NSS: refusing previously loaded certificate from file: %s" , |
1208 | nickname); |
1209 | return SECFailure; |
1210 | } |
1211 | |
1212 | if(NULL == *pRetKey) { |
1213 | failf(data, "NSS: private key not found for certificate: %s" , nickname); |
1214 | return SECFailure; |
1215 | } |
1216 | |
1217 | infof(data, "NSS: using client certificate: %s\n" , nickname); |
1218 | display_cert_info(data, *pRetCert); |
1219 | return SECSuccess; |
1220 | } |
1221 | |
1222 | /* update blocking direction in case of PR_WOULD_BLOCK_ERROR */ |
1223 | static void nss_update_connecting_state(ssl_connect_state state, void *secret) |
1224 | { |
1225 | struct ssl_connect_data *connssl = (struct ssl_connect_data *)secret; |
1226 | if(PR_GetError() != PR_WOULD_BLOCK_ERROR) |
1227 | /* an unrelated error is passing by */ |
1228 | return; |
1229 | |
1230 | switch(connssl->connecting_state) { |
1231 | case ssl_connect_2: |
1232 | case ssl_connect_2_reading: |
1233 | case ssl_connect_2_writing: |
1234 | break; |
1235 | default: |
1236 | /* we are not called from an SSL handshake */ |
1237 | return; |
1238 | } |
1239 | |
1240 | /* update the state accordingly */ |
1241 | connssl->connecting_state = state; |
1242 | } |
1243 | |
1244 | /* recv() wrapper we use to detect blocking direction during SSL handshake */ |
1245 | static PRInt32 nspr_io_recv(PRFileDesc *fd, void *buf, PRInt32 amount, |
1246 | PRIntn flags, PRIntervalTime timeout) |
1247 | { |
1248 | const PRRecvFN recv_fn = fd->lower->methods->recv; |
1249 | const PRInt32 rv = recv_fn(fd->lower, buf, amount, flags, timeout); |
1250 | if(rv < 0) |
1251 | /* check for PR_WOULD_BLOCK_ERROR and update blocking direction */ |
1252 | nss_update_connecting_state(ssl_connect_2_reading, fd->secret); |
1253 | return rv; |
1254 | } |
1255 | |
1256 | /* send() wrapper we use to detect blocking direction during SSL handshake */ |
1257 | static PRInt32 nspr_io_send(PRFileDesc *fd, const void *buf, PRInt32 amount, |
1258 | PRIntn flags, PRIntervalTime timeout) |
1259 | { |
1260 | const PRSendFN send_fn = fd->lower->methods->send; |
1261 | const PRInt32 rv = send_fn(fd->lower, buf, amount, flags, timeout); |
1262 | if(rv < 0) |
1263 | /* check for PR_WOULD_BLOCK_ERROR and update blocking direction */ |
1264 | nss_update_connecting_state(ssl_connect_2_writing, fd->secret); |
1265 | return rv; |
1266 | } |
1267 | |
1268 | /* close() wrapper to avoid assertion failure due to fd->secret != NULL */ |
1269 | static PRStatus nspr_io_close(PRFileDesc *fd) |
1270 | { |
1271 | const PRCloseFN close_fn = PR_GetDefaultIOMethods()->close; |
1272 | fd->secret = NULL; |
1273 | return close_fn(fd); |
1274 | } |
1275 | |
1276 | /* load a PKCS #11 module */ |
1277 | static CURLcode nss_load_module(SECMODModule **pmod, const char *library, |
1278 | const char *name) |
1279 | { |
1280 | char *config_string; |
1281 | SECMODModule *module = *pmod; |
1282 | if(module) |
1283 | /* already loaded */ |
1284 | return CURLE_OK; |
1285 | |
1286 | config_string = aprintf("library=%s name=%s" , library, name); |
1287 | if(!config_string) |
1288 | return CURLE_OUT_OF_MEMORY; |
1289 | |
1290 | module = SECMOD_LoadUserModule(config_string, NULL, PR_FALSE); |
1291 | free(config_string); |
1292 | |
1293 | if(module && module->loaded) { |
1294 | /* loaded successfully */ |
1295 | *pmod = module; |
1296 | return CURLE_OK; |
1297 | } |
1298 | |
1299 | if(module) |
1300 | SECMOD_DestroyModule(module); |
1301 | return CURLE_FAILED_INIT; |
1302 | } |
1303 | |
1304 | /* unload a PKCS #11 module */ |
1305 | static void nss_unload_module(SECMODModule **pmod) |
1306 | { |
1307 | SECMODModule *module = *pmod; |
1308 | if(!module) |
1309 | /* not loaded */ |
1310 | return; |
1311 | |
1312 | if(SECMOD_UnloadUserModule(module) != SECSuccess) |
1313 | /* unload failed */ |
1314 | return; |
1315 | |
1316 | SECMOD_DestroyModule(module); |
1317 | *pmod = NULL; |
1318 | } |
1319 | |
1320 | /* data might be NULL */ |
1321 | static CURLcode nss_init_core(struct Curl_easy *data, const char *cert_dir) |
1322 | { |
1323 | NSSInitParameters initparams; |
1324 | PRErrorCode err; |
1325 | const char *err_name; |
1326 | |
1327 | if(nss_context != NULL) |
1328 | return CURLE_OK; |
1329 | |
1330 | memset((void *) &initparams, '\0', sizeof(initparams)); |
1331 | initparams.length = sizeof(initparams); |
1332 | |
1333 | if(cert_dir) { |
1334 | char *certpath = aprintf("sql:%s" , cert_dir); |
1335 | if(!certpath) |
1336 | return CURLE_OUT_OF_MEMORY; |
1337 | |
1338 | infof(data, "Initializing NSS with certpath: %s\n" , certpath); |
1339 | nss_context = NSS_InitContext(certpath, "" , "" , "" , &initparams, |
1340 | NSS_INIT_READONLY | NSS_INIT_PK11RELOAD); |
1341 | free(certpath); |
1342 | |
1343 | if(nss_context != NULL) |
1344 | return CURLE_OK; |
1345 | |
1346 | err = PR_GetError(); |
1347 | err_name = nss_error_to_name(err); |
1348 | infof(data, "Unable to initialize NSS database: %d (%s)\n" , err, err_name); |
1349 | } |
1350 | |
1351 | infof(data, "Initializing NSS with certpath: none\n" ); |
1352 | nss_context = NSS_InitContext("" , "" , "" , "" , &initparams, NSS_INIT_READONLY |
1353 | | NSS_INIT_NOCERTDB | NSS_INIT_NOMODDB | NSS_INIT_FORCEOPEN |
1354 | | NSS_INIT_NOROOTINIT | NSS_INIT_OPTIMIZESPACE | NSS_INIT_PK11RELOAD); |
1355 | if(nss_context != NULL) |
1356 | return CURLE_OK; |
1357 | |
1358 | err = PR_GetError(); |
1359 | err_name = nss_error_to_name(err); |
1360 | failf(data, "Unable to initialize NSS: %d (%s)" , err, err_name); |
1361 | return CURLE_SSL_CACERT_BADFILE; |
1362 | } |
1363 | |
1364 | /* data might be NULL */ |
1365 | static CURLcode nss_init(struct Curl_easy *data) |
1366 | { |
1367 | char *cert_dir; |
1368 | struct_stat st; |
1369 | CURLcode result; |
1370 | |
1371 | if(initialized) |
1372 | return CURLE_OK; |
1373 | |
1374 | /* list of all CRL items we need to destroy in Curl_nss_cleanup() */ |
1375 | Curl_llist_init(&nss_crl_list, nss_destroy_crl_item); |
1376 | |
1377 | /* First we check if $SSL_DIR points to a valid dir */ |
1378 | cert_dir = getenv("SSL_DIR" ); |
1379 | if(cert_dir) { |
1380 | if((stat(cert_dir, &st) != 0) || |
1381 | (!S_ISDIR(st.st_mode))) { |
1382 | cert_dir = NULL; |
1383 | } |
1384 | } |
1385 | |
1386 | /* Now we check if the default location is a valid dir */ |
1387 | if(!cert_dir) { |
1388 | if((stat(SSL_DIR, &st) == 0) && |
1389 | (S_ISDIR(st.st_mode))) { |
1390 | cert_dir = (char *)SSL_DIR; |
1391 | } |
1392 | } |
1393 | |
1394 | if(nspr_io_identity == PR_INVALID_IO_LAYER) { |
1395 | /* allocate an identity for our own NSPR I/O layer */ |
1396 | nspr_io_identity = PR_GetUniqueIdentity("libcurl" ); |
1397 | if(nspr_io_identity == PR_INVALID_IO_LAYER) |
1398 | return CURLE_OUT_OF_MEMORY; |
1399 | |
1400 | /* the default methods just call down to the lower I/O layer */ |
1401 | memcpy(&nspr_io_methods, PR_GetDefaultIOMethods(), |
1402 | sizeof(nspr_io_methods)); |
1403 | |
1404 | /* override certain methods in the table by our wrappers */ |
1405 | nspr_io_methods.recv = nspr_io_recv; |
1406 | nspr_io_methods.send = nspr_io_send; |
1407 | nspr_io_methods.close = nspr_io_close; |
1408 | } |
1409 | |
1410 | result = nss_init_core(data, cert_dir); |
1411 | if(result) |
1412 | return result; |
1413 | |
1414 | if(!any_cipher_enabled()) |
1415 | NSS_SetDomesticPolicy(); |
1416 | |
1417 | initialized = 1; |
1418 | |
1419 | return CURLE_OK; |
1420 | } |
1421 | |
1422 | /** |
1423 | * Global SSL init |
1424 | * |
1425 | * @retval 0 error initializing SSL |
1426 | * @retval 1 SSL initialized successfully |
1427 | */ |
1428 | static int Curl_nss_init(void) |
1429 | { |
1430 | /* curl_global_init() is not thread-safe so this test is ok */ |
1431 | if(nss_initlock == NULL) { |
1432 | PR_Init(PR_USER_THREAD, PR_PRIORITY_NORMAL, 0); |
1433 | nss_initlock = PR_NewLock(); |
1434 | nss_crllock = PR_NewLock(); |
1435 | nss_findslot_lock = PR_NewLock(); |
1436 | nss_trustload_lock = PR_NewLock(); |
1437 | } |
1438 | |
1439 | /* We will actually initialize NSS later */ |
1440 | |
1441 | return 1; |
1442 | } |
1443 | |
1444 | /* data might be NULL */ |
1445 | CURLcode Curl_nss_force_init(struct Curl_easy *data) |
1446 | { |
1447 | CURLcode result; |
1448 | if(!nss_initlock) { |
1449 | if(data) |
1450 | failf(data, "unable to initialize NSS, curl_global_init() should have " |
1451 | "been called with CURL_GLOBAL_SSL or CURL_GLOBAL_ALL" ); |
1452 | return CURLE_FAILED_INIT; |
1453 | } |
1454 | |
1455 | PR_Lock(nss_initlock); |
1456 | result = nss_init(data); |
1457 | PR_Unlock(nss_initlock); |
1458 | |
1459 | return result; |
1460 | } |
1461 | |
1462 | /* Global cleanup */ |
1463 | static void Curl_nss_cleanup(void) |
1464 | { |
1465 | /* This function isn't required to be threadsafe and this is only done |
1466 | * as a safety feature. |
1467 | */ |
1468 | PR_Lock(nss_initlock); |
1469 | if(initialized) { |
1470 | /* Free references to client certificates held in the SSL session cache. |
1471 | * Omitting this hampers destruction of the security module owning |
1472 | * the certificates. */ |
1473 | SSL_ClearSessionCache(); |
1474 | |
1475 | nss_unload_module(&pem_module); |
1476 | nss_unload_module(&trust_module); |
1477 | NSS_ShutdownContext(nss_context); |
1478 | nss_context = NULL; |
1479 | } |
1480 | |
1481 | /* destroy all CRL items */ |
1482 | Curl_llist_destroy(&nss_crl_list, NULL); |
1483 | |
1484 | PR_Unlock(nss_initlock); |
1485 | |
1486 | PR_DestroyLock(nss_initlock); |
1487 | PR_DestroyLock(nss_crllock); |
1488 | PR_DestroyLock(nss_findslot_lock); |
1489 | PR_DestroyLock(nss_trustload_lock); |
1490 | nss_initlock = NULL; |
1491 | |
1492 | initialized = 0; |
1493 | } |
1494 | |
1495 | /* |
1496 | * This function uses SSL_peek to determine connection status. |
1497 | * |
1498 | * Return codes: |
1499 | * 1 means the connection is still in place |
1500 | * 0 means the connection has been closed |
1501 | * -1 means the connection status is unknown |
1502 | */ |
1503 | static int Curl_nss_check_cxn(struct connectdata *conn) |
1504 | { |
1505 | struct ssl_connect_data *connssl = &conn->ssl[FIRSTSOCKET]; |
1506 | int rc; |
1507 | char buf; |
1508 | |
1509 | rc = |
1510 | PR_Recv(BACKEND->handle, (void *)&buf, 1, PR_MSG_PEEK, |
1511 | PR_SecondsToInterval(1)); |
1512 | if(rc > 0) |
1513 | return 1; /* connection still in place */ |
1514 | |
1515 | if(rc == 0) |
1516 | return 0; /* connection has been closed */ |
1517 | |
1518 | return -1; /* connection status unknown */ |
1519 | } |
1520 | |
1521 | static void nss_close(struct ssl_connect_data *connssl) |
1522 | { |
1523 | /* before the cleanup, check whether we are using a client certificate */ |
1524 | const bool client_cert = (BACKEND->client_nickname != NULL) |
1525 | || (BACKEND->obj_clicert != NULL); |
1526 | |
1527 | free(BACKEND->client_nickname); |
1528 | BACKEND->client_nickname = NULL; |
1529 | |
1530 | /* destroy all NSS objects in order to avoid failure of NSS shutdown */ |
1531 | Curl_llist_destroy(&BACKEND->obj_list, NULL); |
1532 | BACKEND->obj_clicert = NULL; |
1533 | |
1534 | if(BACKEND->handle) { |
1535 | if(client_cert) |
1536 | /* A server might require different authentication based on the |
1537 | * particular path being requested by the client. To support this |
1538 | * scenario, we must ensure that a connection will never reuse the |
1539 | * authentication data from a previous connection. */ |
1540 | SSL_InvalidateSession(BACKEND->handle); |
1541 | |
1542 | PR_Close(BACKEND->handle); |
1543 | BACKEND->handle = NULL; |
1544 | } |
1545 | } |
1546 | |
1547 | /* |
1548 | * This function is called when an SSL connection is closed. |
1549 | */ |
1550 | static void Curl_nss_close(struct connectdata *conn, int sockindex) |
1551 | { |
1552 | struct ssl_connect_data *connssl = &conn->ssl[sockindex]; |
1553 | struct ssl_connect_data *connssl_proxy = &conn->proxy_ssl[sockindex]; |
1554 | |
1555 | if(BACKEND->handle || connssl_proxy->backend->handle) { |
1556 | /* NSS closes the socket we previously handed to it, so we must mark it |
1557 | as closed to avoid double close */ |
1558 | fake_sclose(conn->sock[sockindex]); |
1559 | conn->sock[sockindex] = CURL_SOCKET_BAD; |
1560 | } |
1561 | |
1562 | if(BACKEND->handle) |
1563 | /* nss_close(connssl) will transitively close also |
1564 | connssl_proxy->backend->handle if both are used. Clear it to avoid |
1565 | a double close leading to crash. */ |
1566 | connssl_proxy->backend->handle = NULL; |
1567 | |
1568 | nss_close(connssl); |
1569 | nss_close(connssl_proxy); |
1570 | } |
1571 | |
1572 | /* return true if NSS can provide error code (and possibly msg) for the |
1573 | error */ |
1574 | static bool is_nss_error(CURLcode err) |
1575 | { |
1576 | switch(err) { |
1577 | case CURLE_PEER_FAILED_VERIFICATION: |
1578 | case CURLE_SSL_CERTPROBLEM: |
1579 | case CURLE_SSL_CONNECT_ERROR: |
1580 | case CURLE_SSL_ISSUER_ERROR: |
1581 | return true; |
1582 | |
1583 | default: |
1584 | return false; |
1585 | } |
1586 | } |
1587 | |
1588 | /* return true if the given error code is related to a client certificate */ |
1589 | static bool is_cc_error(PRInt32 err) |
1590 | { |
1591 | switch(err) { |
1592 | case SSL_ERROR_BAD_CERT_ALERT: |
1593 | case SSL_ERROR_EXPIRED_CERT_ALERT: |
1594 | case SSL_ERROR_REVOKED_CERT_ALERT: |
1595 | return true; |
1596 | |
1597 | default: |
1598 | return false; |
1599 | } |
1600 | } |
1601 | |
1602 | static Curl_recv nss_recv; |
1603 | static Curl_send nss_send; |
1604 | |
1605 | static CURLcode nss_load_ca_certificates(struct connectdata *conn, |
1606 | int sockindex) |
1607 | { |
1608 | struct Curl_easy *data = conn->data; |
1609 | const char *cafile = SSL_CONN_CONFIG(CAfile); |
1610 | const char *capath = SSL_CONN_CONFIG(CApath); |
1611 | bool use_trust_module; |
1612 | CURLcode result = CURLE_OK; |
1613 | |
1614 | /* treat empty string as unset */ |
1615 | if(cafile && !cafile[0]) |
1616 | cafile = NULL; |
1617 | if(capath && !capath[0]) |
1618 | capath = NULL; |
1619 | |
1620 | infof(data, " CAfile: %s\n CApath: %s\n" , |
1621 | cafile ? cafile : "none" , |
1622 | capath ? capath : "none" ); |
1623 | |
1624 | /* load libnssckbi.so if no other trust roots were specified */ |
1625 | use_trust_module = !cafile && !capath; |
1626 | |
1627 | PR_Lock(nss_trustload_lock); |
1628 | if(use_trust_module && !trust_module) { |
1629 | /* libnssckbi.so needed but not yet loaded --> load it! */ |
1630 | result = nss_load_module(&trust_module, trust_library, "trust" ); |
1631 | infof(data, "%s %s\n" , (result) ? "failed to load" : "loaded" , |
1632 | trust_library); |
1633 | if(result == CURLE_FAILED_INIT) |
1634 | /* If libnssckbi.so is not available (or fails to load), one can still |
1635 | use CA certificates stored in NSS database. Ignore the failure. */ |
1636 | result = CURLE_OK; |
1637 | } |
1638 | else if(!use_trust_module && trust_module) { |
1639 | /* libnssckbi.so not needed but already loaded --> unload it! */ |
1640 | infof(data, "unloading %s\n" , trust_library); |
1641 | nss_unload_module(&trust_module); |
1642 | } |
1643 | PR_Unlock(nss_trustload_lock); |
1644 | |
1645 | if(cafile) |
1646 | result = nss_load_cert(&conn->ssl[sockindex], cafile, PR_TRUE); |
1647 | |
1648 | if(result) |
1649 | return result; |
1650 | |
1651 | if(capath) { |
1652 | struct_stat st; |
1653 | if(stat(capath, &st) == -1) |
1654 | return CURLE_SSL_CACERT_BADFILE; |
1655 | |
1656 | if(S_ISDIR(st.st_mode)) { |
1657 | PRDirEntry *entry; |
1658 | PRDir *dir = PR_OpenDir(capath); |
1659 | if(!dir) |
1660 | return CURLE_SSL_CACERT_BADFILE; |
1661 | |
1662 | while((entry = PR_ReadDir(dir, PR_SKIP_BOTH | PR_SKIP_HIDDEN))) { |
1663 | char *fullpath = aprintf("%s/%s" , capath, entry->name); |
1664 | if(!fullpath) { |
1665 | PR_CloseDir(dir); |
1666 | return CURLE_OUT_OF_MEMORY; |
1667 | } |
1668 | |
1669 | if(CURLE_OK != nss_load_cert(&conn->ssl[sockindex], fullpath, PR_TRUE)) |
1670 | /* This is purposefully tolerant of errors so non-PEM files can |
1671 | * be in the same directory */ |
1672 | infof(data, "failed to load '%s' from CURLOPT_CAPATH\n" , fullpath); |
1673 | |
1674 | free(fullpath); |
1675 | } |
1676 | |
1677 | PR_CloseDir(dir); |
1678 | } |
1679 | else |
1680 | infof(data, "warning: CURLOPT_CAPATH not a directory (%s)\n" , capath); |
1681 | } |
1682 | |
1683 | return CURLE_OK; |
1684 | } |
1685 | |
1686 | static CURLcode nss_sslver_from_curl(PRUint16 *nssver, long version) |
1687 | { |
1688 | switch(version) { |
1689 | case CURL_SSLVERSION_SSLv2: |
1690 | *nssver = SSL_LIBRARY_VERSION_2; |
1691 | return CURLE_OK; |
1692 | |
1693 | case CURL_SSLVERSION_SSLv3: |
1694 | *nssver = SSL_LIBRARY_VERSION_3_0; |
1695 | return CURLE_OK; |
1696 | |
1697 | case CURL_SSLVERSION_TLSv1_0: |
1698 | *nssver = SSL_LIBRARY_VERSION_TLS_1_0; |
1699 | return CURLE_OK; |
1700 | |
1701 | case CURL_SSLVERSION_TLSv1_1: |
1702 | #ifdef SSL_LIBRARY_VERSION_TLS_1_1 |
1703 | *nssver = SSL_LIBRARY_VERSION_TLS_1_1; |
1704 | return CURLE_OK; |
1705 | #else |
1706 | return CURLE_SSL_CONNECT_ERROR; |
1707 | #endif |
1708 | |
1709 | case CURL_SSLVERSION_TLSv1_2: |
1710 | #ifdef SSL_LIBRARY_VERSION_TLS_1_2 |
1711 | *nssver = SSL_LIBRARY_VERSION_TLS_1_2; |
1712 | return CURLE_OK; |
1713 | #else |
1714 | return CURLE_SSL_CONNECT_ERROR; |
1715 | #endif |
1716 | |
1717 | case CURL_SSLVERSION_TLSv1_3: |
1718 | #ifdef SSL_LIBRARY_VERSION_TLS_1_3 |
1719 | *nssver = SSL_LIBRARY_VERSION_TLS_1_3; |
1720 | return CURLE_OK; |
1721 | #else |
1722 | return CURLE_SSL_CONNECT_ERROR; |
1723 | #endif |
1724 | |
1725 | default: |
1726 | return CURLE_SSL_CONNECT_ERROR; |
1727 | } |
1728 | } |
1729 | |
1730 | static CURLcode nss_init_sslver(SSLVersionRange *sslver, |
1731 | struct Curl_easy *data, |
1732 | struct connectdata *conn) |
1733 | { |
1734 | CURLcode result; |
1735 | const long min = SSL_CONN_CONFIG(version); |
1736 | const long max = SSL_CONN_CONFIG(version_max); |
1737 | SSLVersionRange vrange; |
1738 | |
1739 | switch(min) { |
1740 | case CURL_SSLVERSION_TLSv1: |
1741 | case CURL_SSLVERSION_DEFAULT: |
1742 | /* Bump our minimum TLS version if NSS has stricter requirements. */ |
1743 | if(SSL_VersionRangeGetDefault(ssl_variant_stream, &vrange) != SECSuccess) |
1744 | return CURLE_SSL_CONNECT_ERROR; |
1745 | if(sslver->min < vrange.min) |
1746 | sslver->min = vrange.min; |
1747 | break; |
1748 | default: |
1749 | result = nss_sslver_from_curl(&sslver->min, min); |
1750 | if(result) { |
1751 | failf(data, "unsupported min version passed via CURLOPT_SSLVERSION" ); |
1752 | return result; |
1753 | } |
1754 | } |
1755 | |
1756 | switch(max) { |
1757 | case CURL_SSLVERSION_MAX_NONE: |
1758 | case CURL_SSLVERSION_MAX_DEFAULT: |
1759 | break; |
1760 | default: |
1761 | result = nss_sslver_from_curl(&sslver->max, max >> 16); |
1762 | if(result) { |
1763 | failf(data, "unsupported max version passed via CURLOPT_SSLVERSION" ); |
1764 | return result; |
1765 | } |
1766 | } |
1767 | |
1768 | return CURLE_OK; |
1769 | } |
1770 | |
1771 | static CURLcode nss_fail_connect(struct ssl_connect_data *connssl, |
1772 | struct Curl_easy *data, |
1773 | CURLcode curlerr) |
1774 | { |
1775 | PRErrorCode err = 0; |
1776 | |
1777 | if(is_nss_error(curlerr)) { |
1778 | /* read NSPR error code */ |
1779 | err = PR_GetError(); |
1780 | if(is_cc_error(err)) |
1781 | curlerr = CURLE_SSL_CERTPROBLEM; |
1782 | |
1783 | /* print the error number and error string */ |
1784 | infof(data, "NSS error %d (%s)\n" , err, nss_error_to_name(err)); |
1785 | |
1786 | /* print a human-readable message describing the error if available */ |
1787 | nss_print_error_message(data, err); |
1788 | } |
1789 | |
1790 | /* cleanup on connection failure */ |
1791 | Curl_llist_destroy(&BACKEND->obj_list, NULL); |
1792 | |
1793 | return curlerr; |
1794 | } |
1795 | |
1796 | /* Switch the SSL socket into blocking or non-blocking mode. */ |
1797 | static CURLcode nss_set_blocking(struct ssl_connect_data *connssl, |
1798 | struct Curl_easy *data, |
1799 | bool blocking) |
1800 | { |
1801 | static PRSocketOptionData sock_opt; |
1802 | sock_opt.option = PR_SockOpt_Nonblocking; |
1803 | sock_opt.value.non_blocking = !blocking; |
1804 | |
1805 | if(PR_SetSocketOption(BACKEND->handle, &sock_opt) != PR_SUCCESS) |
1806 | return nss_fail_connect(connssl, data, CURLE_SSL_CONNECT_ERROR); |
1807 | |
1808 | return CURLE_OK; |
1809 | } |
1810 | |
1811 | static CURLcode nss_setup_connect(struct connectdata *conn, int sockindex) |
1812 | { |
1813 | PRFileDesc *model = NULL; |
1814 | PRFileDesc *nspr_io = NULL; |
1815 | PRFileDesc *nspr_io_stub = NULL; |
1816 | PRBool ssl_no_cache; |
1817 | PRBool ssl_cbc_random_iv; |
1818 | struct Curl_easy *data = conn->data; |
1819 | curl_socket_t sockfd = conn->sock[sockindex]; |
1820 | struct ssl_connect_data *connssl = &conn->ssl[sockindex]; |
1821 | CURLcode result; |
1822 | bool second_layer = FALSE; |
1823 | SSLVersionRange sslver_supported; |
1824 | |
1825 | SSLVersionRange sslver = { |
1826 | SSL_LIBRARY_VERSION_TLS_1_0, /* min */ |
1827 | #ifdef SSL_LIBRARY_VERSION_TLS_1_3 |
1828 | SSL_LIBRARY_VERSION_TLS_1_3 /* max */ |
1829 | #elif defined SSL_LIBRARY_VERSION_TLS_1_2 |
1830 | SSL_LIBRARY_VERSION_TLS_1_2 |
1831 | #elif defined SSL_LIBRARY_VERSION_TLS_1_1 |
1832 | SSL_LIBRARY_VERSION_TLS_1_1 |
1833 | #else |
1834 | SSL_LIBRARY_VERSION_TLS_1_0 |
1835 | #endif |
1836 | }; |
1837 | |
1838 | BACKEND->data = data; |
1839 | |
1840 | /* list of all NSS objects we need to destroy in Curl_nss_close() */ |
1841 | Curl_llist_init(&BACKEND->obj_list, nss_destroy_object); |
1842 | |
1843 | PR_Lock(nss_initlock); |
1844 | result = nss_init(conn->data); |
1845 | if(result) { |
1846 | PR_Unlock(nss_initlock); |
1847 | goto error; |
1848 | } |
1849 | |
1850 | PK11_SetPasswordFunc(nss_get_password); |
1851 | |
1852 | result = nss_load_module(&pem_module, pem_library, "PEM" ); |
1853 | PR_Unlock(nss_initlock); |
1854 | if(result == CURLE_FAILED_INIT) |
1855 | infof(data, "WARNING: failed to load NSS PEM library %s. Using " |
1856 | "OpenSSL PEM certificates will not work.\n" , pem_library); |
1857 | else if(result) |
1858 | goto error; |
1859 | |
1860 | result = CURLE_SSL_CONNECT_ERROR; |
1861 | |
1862 | model = PR_NewTCPSocket(); |
1863 | if(!model) |
1864 | goto error; |
1865 | model = SSL_ImportFD(NULL, model); |
1866 | |
1867 | if(SSL_OptionSet(model, SSL_SECURITY, PR_TRUE) != SECSuccess) |
1868 | goto error; |
1869 | if(SSL_OptionSet(model, SSL_HANDSHAKE_AS_SERVER, PR_FALSE) != SECSuccess) |
1870 | goto error; |
1871 | if(SSL_OptionSet(model, SSL_HANDSHAKE_AS_CLIENT, PR_TRUE) != SECSuccess) |
1872 | goto error; |
1873 | |
1874 | /* do not use SSL cache if disabled or we are not going to verify peer */ |
1875 | ssl_no_cache = (SSL_SET_OPTION(primary.sessionid) |
1876 | && SSL_CONN_CONFIG(verifypeer)) ? PR_FALSE : PR_TRUE; |
1877 | if(SSL_OptionSet(model, SSL_NO_CACHE, ssl_no_cache) != SECSuccess) |
1878 | goto error; |
1879 | |
1880 | /* enable/disable the requested SSL version(s) */ |
1881 | if(nss_init_sslver(&sslver, data, conn) != CURLE_OK) |
1882 | goto error; |
1883 | if(SSL_VersionRangeGetSupported(ssl_variant_stream, |
1884 | &sslver_supported) != SECSuccess) |
1885 | goto error; |
1886 | if(sslver_supported.max < sslver.max && sslver_supported.max >= sslver.min) { |
1887 | char *sslver_req_str, *sslver_supp_str; |
1888 | sslver_req_str = nss_sslver_to_name(sslver.max); |
1889 | sslver_supp_str = nss_sslver_to_name(sslver_supported.max); |
1890 | if(sslver_req_str && sslver_supp_str) |
1891 | infof(data, "Falling back from %s to max supported SSL version (%s)\n" , |
1892 | sslver_req_str, sslver_supp_str); |
1893 | free(sslver_req_str); |
1894 | free(sslver_supp_str); |
1895 | sslver.max = sslver_supported.max; |
1896 | } |
1897 | if(SSL_VersionRangeSet(model, &sslver) != SECSuccess) |
1898 | goto error; |
1899 | |
1900 | ssl_cbc_random_iv = !SSL_SET_OPTION(enable_beast); |
1901 | #ifdef SSL_CBC_RANDOM_IV |
1902 | /* unless the user explicitly asks to allow the protocol vulnerability, we |
1903 | use the work-around */ |
1904 | if(SSL_OptionSet(model, SSL_CBC_RANDOM_IV, ssl_cbc_random_iv) != SECSuccess) |
1905 | infof(data, "warning: failed to set SSL_CBC_RANDOM_IV = %d\n" , |
1906 | ssl_cbc_random_iv); |
1907 | #else |
1908 | if(ssl_cbc_random_iv) |
1909 | infof(data, "warning: support for SSL_CBC_RANDOM_IV not compiled in\n" ); |
1910 | #endif |
1911 | |
1912 | if(SSL_CONN_CONFIG(cipher_list)) { |
1913 | if(set_ciphers(data, model, SSL_CONN_CONFIG(cipher_list)) != SECSuccess) { |
1914 | result = CURLE_SSL_CIPHER; |
1915 | goto error; |
1916 | } |
1917 | } |
1918 | |
1919 | if(!SSL_CONN_CONFIG(verifypeer) && SSL_CONN_CONFIG(verifyhost)) |
1920 | infof(data, "warning: ignoring value of ssl.verifyhost\n" ); |
1921 | |
1922 | /* bypass the default SSL_AuthCertificate() hook in case we do not want to |
1923 | * verify peer */ |
1924 | if(SSL_AuthCertificateHook(model, nss_auth_cert_hook, conn) != SECSuccess) |
1925 | goto error; |
1926 | |
1927 | /* not checked yet */ |
1928 | if(SSL_IS_PROXY()) |
1929 | data->set.proxy_ssl.certverifyresult = 0; |
1930 | else |
1931 | data->set.ssl.certverifyresult = 0; |
1932 | |
1933 | if(SSL_BadCertHook(model, BadCertHandler, conn) != SECSuccess) |
1934 | goto error; |
1935 | |
1936 | if(SSL_HandshakeCallback(model, HandshakeCallback, conn) != SECSuccess) |
1937 | goto error; |
1938 | |
1939 | { |
1940 | const CURLcode rv = nss_load_ca_certificates(conn, sockindex); |
1941 | if((rv == CURLE_SSL_CACERT_BADFILE) && !SSL_CONN_CONFIG(verifypeer)) |
1942 | /* not a fatal error because we are not going to verify the peer */ |
1943 | infof(data, "warning: CA certificates failed to load\n" ); |
1944 | else if(rv) { |
1945 | result = rv; |
1946 | goto error; |
1947 | } |
1948 | } |
1949 | |
1950 | if(SSL_SET_OPTION(CRLfile)) { |
1951 | const CURLcode rv = nss_load_crl(SSL_SET_OPTION(CRLfile)); |
1952 | if(rv) { |
1953 | result = rv; |
1954 | goto error; |
1955 | } |
1956 | infof(data, " CRLfile: %s\n" , SSL_SET_OPTION(CRLfile)); |
1957 | } |
1958 | |
1959 | if(SSL_SET_OPTION(cert)) { |
1960 | char *nickname = dup_nickname(data, SSL_SET_OPTION(cert)); |
1961 | if(nickname) { |
1962 | /* we are not going to use libnsspem.so to read the client cert */ |
1963 | BACKEND->obj_clicert = NULL; |
1964 | } |
1965 | else { |
1966 | CURLcode rv = cert_stuff(conn, sockindex, SSL_SET_OPTION(cert), |
1967 | SSL_SET_OPTION(key)); |
1968 | if(rv) { |
1969 | /* failf() is already done in cert_stuff() */ |
1970 | result = rv; |
1971 | goto error; |
1972 | } |
1973 | } |
1974 | |
1975 | /* store the nickname for SelectClientCert() called during handshake */ |
1976 | BACKEND->client_nickname = nickname; |
1977 | } |
1978 | else |
1979 | BACKEND->client_nickname = NULL; |
1980 | |
1981 | if(SSL_GetClientAuthDataHook(model, SelectClientCert, |
1982 | (void *)connssl) != SECSuccess) { |
1983 | result = CURLE_SSL_CERTPROBLEM; |
1984 | goto error; |
1985 | } |
1986 | |
1987 | if(conn->proxy_ssl[sockindex].use) { |
1988 | DEBUGASSERT(ssl_connection_complete == conn->proxy_ssl[sockindex].state); |
1989 | DEBUGASSERT(conn->proxy_ssl[sockindex].backend->handle != NULL); |
1990 | nspr_io = conn->proxy_ssl[sockindex].backend->handle; |
1991 | second_layer = TRUE; |
1992 | } |
1993 | else { |
1994 | /* wrap OS file descriptor by NSPR's file descriptor abstraction */ |
1995 | nspr_io = PR_ImportTCPSocket(sockfd); |
1996 | if(!nspr_io) |
1997 | goto error; |
1998 | } |
1999 | |
2000 | /* create our own NSPR I/O layer */ |
2001 | nspr_io_stub = PR_CreateIOLayerStub(nspr_io_identity, &nspr_io_methods); |
2002 | if(!nspr_io_stub) { |
2003 | if(!second_layer) |
2004 | PR_Close(nspr_io); |
2005 | goto error; |
2006 | } |
2007 | |
2008 | /* make the per-connection data accessible from NSPR I/O callbacks */ |
2009 | nspr_io_stub->secret = (void *)connssl; |
2010 | |
2011 | /* push our new layer to the NSPR I/O stack */ |
2012 | if(PR_PushIOLayer(nspr_io, PR_TOP_IO_LAYER, nspr_io_stub) != PR_SUCCESS) { |
2013 | if(!second_layer) |
2014 | PR_Close(nspr_io); |
2015 | PR_Close(nspr_io_stub); |
2016 | goto error; |
2017 | } |
2018 | |
2019 | /* import our model socket onto the current I/O stack */ |
2020 | BACKEND->handle = SSL_ImportFD(model, nspr_io); |
2021 | if(!BACKEND->handle) { |
2022 | if(!second_layer) |
2023 | PR_Close(nspr_io); |
2024 | goto error; |
2025 | } |
2026 | |
2027 | PR_Close(model); /* We don't need this any more */ |
2028 | model = NULL; |
2029 | |
2030 | /* This is the password associated with the cert that we're using */ |
2031 | if(SSL_SET_OPTION(key_passwd)) { |
2032 | SSL_SetPKCS11PinArg(BACKEND->handle, SSL_SET_OPTION(key_passwd)); |
2033 | } |
2034 | |
2035 | #ifdef SSL_ENABLE_OCSP_STAPLING |
2036 | if(SSL_CONN_CONFIG(verifystatus)) { |
2037 | if(SSL_OptionSet(BACKEND->handle, SSL_ENABLE_OCSP_STAPLING, PR_TRUE) |
2038 | != SECSuccess) |
2039 | goto error; |
2040 | } |
2041 | #endif |
2042 | |
2043 | #ifdef SSL_ENABLE_NPN |
2044 | if(SSL_OptionSet(BACKEND->handle, SSL_ENABLE_NPN, conn->bits.tls_enable_npn |
2045 | ? PR_TRUE : PR_FALSE) != SECSuccess) |
2046 | goto error; |
2047 | #endif |
2048 | |
2049 | #ifdef SSL_ENABLE_ALPN |
2050 | if(SSL_OptionSet(BACKEND->handle, SSL_ENABLE_ALPN, conn->bits.tls_enable_alpn |
2051 | ? PR_TRUE : PR_FALSE) != SECSuccess) |
2052 | goto error; |
2053 | #endif |
2054 | |
2055 | #if NSSVERNUM >= 0x030f04 /* 3.15.4 */ |
2056 | if(data->set.ssl.falsestart) { |
2057 | if(SSL_OptionSet(BACKEND->handle, SSL_ENABLE_FALSE_START, PR_TRUE) |
2058 | != SECSuccess) |
2059 | goto error; |
2060 | |
2061 | if(SSL_SetCanFalseStartCallback(BACKEND->handle, CanFalseStartCallback, |
2062 | conn) != SECSuccess) |
2063 | goto error; |
2064 | } |
2065 | #endif |
2066 | |
2067 | #if defined(SSL_ENABLE_NPN) || defined(SSL_ENABLE_ALPN) |
2068 | if(conn->bits.tls_enable_npn || conn->bits.tls_enable_alpn) { |
2069 | int cur = 0; |
2070 | unsigned char protocols[128]; |
2071 | |
2072 | #ifdef USE_NGHTTP2 |
2073 | if(data->set.httpversion >= CURL_HTTP_VERSION_2 && |
2074 | (!SSL_IS_PROXY() || !conn->bits.tunnel_proxy)) { |
2075 | protocols[cur++] = NGHTTP2_PROTO_VERSION_ID_LEN; |
2076 | memcpy(&protocols[cur], NGHTTP2_PROTO_VERSION_ID, |
2077 | NGHTTP2_PROTO_VERSION_ID_LEN); |
2078 | cur += NGHTTP2_PROTO_VERSION_ID_LEN; |
2079 | } |
2080 | #endif |
2081 | protocols[cur++] = ALPN_HTTP_1_1_LENGTH; |
2082 | memcpy(&protocols[cur], ALPN_HTTP_1_1, ALPN_HTTP_1_1_LENGTH); |
2083 | cur += ALPN_HTTP_1_1_LENGTH; |
2084 | |
2085 | if(SSL_SetNextProtoNego(BACKEND->handle, protocols, cur) != SECSuccess) |
2086 | goto error; |
2087 | } |
2088 | #endif |
2089 | |
2090 | |
2091 | /* Force handshake on next I/O */ |
2092 | if(SSL_ResetHandshake(BACKEND->handle, /* asServer */ PR_FALSE) |
2093 | != SECSuccess) |
2094 | goto error; |
2095 | |
2096 | /* propagate hostname to the TLS layer */ |
2097 | if(SSL_SetURL(BACKEND->handle, SSL_IS_PROXY() ? conn->http_proxy.host.name : |
2098 | conn->host.name) != SECSuccess) |
2099 | goto error; |
2100 | |
2101 | /* prevent NSS from re-using the session for a different hostname */ |
2102 | if(SSL_SetSockPeerID(BACKEND->handle, SSL_IS_PROXY() ? |
2103 | conn->http_proxy.host.name : conn->host.name) |
2104 | != SECSuccess) |
2105 | goto error; |
2106 | |
2107 | return CURLE_OK; |
2108 | |
2109 | error: |
2110 | if(model) |
2111 | PR_Close(model); |
2112 | |
2113 | return nss_fail_connect(connssl, data, result); |
2114 | } |
2115 | |
2116 | static CURLcode nss_do_connect(struct connectdata *conn, int sockindex) |
2117 | { |
2118 | struct ssl_connect_data *connssl = &conn->ssl[sockindex]; |
2119 | struct Curl_easy *data = conn->data; |
2120 | CURLcode result = CURLE_SSL_CONNECT_ERROR; |
2121 | PRUint32 timeout; |
2122 | long * const certverifyresult = SSL_IS_PROXY() ? |
2123 | &data->set.proxy_ssl.certverifyresult : &data->set.ssl.certverifyresult; |
2124 | const char * const pinnedpubkey = SSL_IS_PROXY() ? |
2125 | data->set.str[STRING_SSL_PINNEDPUBLICKEY_PROXY] : |
2126 | data->set.str[STRING_SSL_PINNEDPUBLICKEY_ORIG]; |
2127 | |
2128 | |
2129 | /* check timeout situation */ |
2130 | const timediff_t time_left = Curl_timeleft(data, NULL, TRUE); |
2131 | if(time_left < 0) { |
2132 | failf(data, "timed out before SSL handshake" ); |
2133 | result = CURLE_OPERATION_TIMEDOUT; |
2134 | goto error; |
2135 | } |
2136 | |
2137 | /* Force the handshake now */ |
2138 | timeout = PR_MillisecondsToInterval((PRUint32) time_left); |
2139 | if(SSL_ForceHandshakeWithTimeout(BACKEND->handle, timeout) != SECSuccess) { |
2140 | if(PR_GetError() == PR_WOULD_BLOCK_ERROR) |
2141 | /* blocking direction is updated by nss_update_connecting_state() */ |
2142 | return CURLE_AGAIN; |
2143 | else if(*certverifyresult == SSL_ERROR_BAD_CERT_DOMAIN) |
2144 | result = CURLE_PEER_FAILED_VERIFICATION; |
2145 | else if(*certverifyresult != 0) |
2146 | result = CURLE_PEER_FAILED_VERIFICATION; |
2147 | goto error; |
2148 | } |
2149 | |
2150 | result = display_conn_info(conn, BACKEND->handle); |
2151 | if(result) |
2152 | goto error; |
2153 | |
2154 | if(SSL_SET_OPTION(issuercert)) { |
2155 | SECStatus ret = SECFailure; |
2156 | char *nickname = dup_nickname(data, SSL_SET_OPTION(issuercert)); |
2157 | if(nickname) { |
2158 | /* we support only nicknames in case of issuercert for now */ |
2159 | ret = check_issuer_cert(BACKEND->handle, nickname); |
2160 | free(nickname); |
2161 | } |
2162 | |
2163 | if(SECFailure == ret) { |
2164 | infof(data, "SSL certificate issuer check failed\n" ); |
2165 | result = CURLE_SSL_ISSUER_ERROR; |
2166 | goto error; |
2167 | } |
2168 | else { |
2169 | infof(data, "SSL certificate issuer check ok\n" ); |
2170 | } |
2171 | } |
2172 | |
2173 | result = cmp_peer_pubkey(connssl, pinnedpubkey); |
2174 | if(result) |
2175 | /* status already printed */ |
2176 | goto error; |
2177 | |
2178 | return CURLE_OK; |
2179 | |
2180 | error: |
2181 | return nss_fail_connect(connssl, data, result); |
2182 | } |
2183 | |
2184 | static CURLcode nss_connect_common(struct connectdata *conn, int sockindex, |
2185 | bool *done) |
2186 | { |
2187 | struct ssl_connect_data *connssl = &conn->ssl[sockindex]; |
2188 | struct Curl_easy *data = conn->data; |
2189 | const bool blocking = (done == NULL); |
2190 | CURLcode result; |
2191 | |
2192 | if(connssl->state == ssl_connection_complete) { |
2193 | if(!blocking) |
2194 | *done = TRUE; |
2195 | return CURLE_OK; |
2196 | } |
2197 | |
2198 | if(connssl->connecting_state == ssl_connect_1) { |
2199 | result = nss_setup_connect(conn, sockindex); |
2200 | if(result) |
2201 | /* we do not expect CURLE_AGAIN from nss_setup_connect() */ |
2202 | return result; |
2203 | |
2204 | connssl->connecting_state = ssl_connect_2; |
2205 | } |
2206 | |
2207 | /* enable/disable blocking mode before handshake */ |
2208 | result = nss_set_blocking(connssl, data, blocking); |
2209 | if(result) |
2210 | return result; |
2211 | |
2212 | result = nss_do_connect(conn, sockindex); |
2213 | switch(result) { |
2214 | case CURLE_OK: |
2215 | break; |
2216 | case CURLE_AGAIN: |
2217 | if(!blocking) |
2218 | /* CURLE_AGAIN in non-blocking mode is not an error */ |
2219 | return CURLE_OK; |
2220 | /* FALLTHROUGH */ |
2221 | default: |
2222 | return result; |
2223 | } |
2224 | |
2225 | if(blocking) { |
2226 | /* in blocking mode, set NSS non-blocking mode _after_ SSL handshake */ |
2227 | result = nss_set_blocking(connssl, data, /* blocking */ FALSE); |
2228 | if(result) |
2229 | return result; |
2230 | } |
2231 | else |
2232 | /* signal completed SSL handshake */ |
2233 | *done = TRUE; |
2234 | |
2235 | connssl->state = ssl_connection_complete; |
2236 | conn->recv[sockindex] = nss_recv; |
2237 | conn->send[sockindex] = nss_send; |
2238 | |
2239 | /* ssl_connect_done is never used outside, go back to the initial state */ |
2240 | connssl->connecting_state = ssl_connect_1; |
2241 | |
2242 | return CURLE_OK; |
2243 | } |
2244 | |
2245 | static CURLcode Curl_nss_connect(struct connectdata *conn, int sockindex) |
2246 | { |
2247 | return nss_connect_common(conn, sockindex, /* blocking */ NULL); |
2248 | } |
2249 | |
2250 | static CURLcode Curl_nss_connect_nonblocking(struct connectdata *conn, |
2251 | int sockindex, bool *done) |
2252 | { |
2253 | return nss_connect_common(conn, sockindex, done); |
2254 | } |
2255 | |
2256 | static ssize_t nss_send(struct connectdata *conn, /* connection data */ |
2257 | int sockindex, /* socketindex */ |
2258 | const void *mem, /* send this data */ |
2259 | size_t len, /* amount to write */ |
2260 | CURLcode *curlcode) |
2261 | { |
2262 | struct ssl_connect_data *connssl = &conn->ssl[sockindex]; |
2263 | ssize_t rc; |
2264 | |
2265 | /* The SelectClientCert() hook uses this for infof() and failf() but the |
2266 | handle stored in nss_setup_connect() could have already been freed. */ |
2267 | BACKEND->data = conn->data; |
2268 | |
2269 | rc = PR_Send(BACKEND->handle, mem, (int)len, 0, PR_INTERVAL_NO_WAIT); |
2270 | if(rc < 0) { |
2271 | PRInt32 err = PR_GetError(); |
2272 | if(err == PR_WOULD_BLOCK_ERROR) |
2273 | *curlcode = CURLE_AGAIN; |
2274 | else { |
2275 | /* print the error number and error string */ |
2276 | const char *err_name = nss_error_to_name(err); |
2277 | infof(conn->data, "SSL write: error %d (%s)\n" , err, err_name); |
2278 | |
2279 | /* print a human-readable message describing the error if available */ |
2280 | nss_print_error_message(conn->data, err); |
2281 | |
2282 | *curlcode = (is_cc_error(err)) |
2283 | ? CURLE_SSL_CERTPROBLEM |
2284 | : CURLE_SEND_ERROR; |
2285 | } |
2286 | |
2287 | return -1; |
2288 | } |
2289 | |
2290 | return rc; /* number of bytes */ |
2291 | } |
2292 | |
2293 | static ssize_t nss_recv(struct connectdata *conn, /* connection data */ |
2294 | int sockindex, /* socketindex */ |
2295 | char *buf, /* store read data here */ |
2296 | size_t buffersize, /* max amount to read */ |
2297 | CURLcode *curlcode) |
2298 | { |
2299 | struct ssl_connect_data *connssl = &conn->ssl[sockindex]; |
2300 | ssize_t nread; |
2301 | |
2302 | /* The SelectClientCert() hook uses this for infof() and failf() but the |
2303 | handle stored in nss_setup_connect() could have already been freed. */ |
2304 | BACKEND->data = conn->data; |
2305 | |
2306 | nread = PR_Recv(BACKEND->handle, buf, (int)buffersize, 0, |
2307 | PR_INTERVAL_NO_WAIT); |
2308 | if(nread < 0) { |
2309 | /* failed SSL read */ |
2310 | PRInt32 err = PR_GetError(); |
2311 | |
2312 | if(err == PR_WOULD_BLOCK_ERROR) |
2313 | *curlcode = CURLE_AGAIN; |
2314 | else { |
2315 | /* print the error number and error string */ |
2316 | const char *err_name = nss_error_to_name(err); |
2317 | infof(conn->data, "SSL read: errno %d (%s)\n" , err, err_name); |
2318 | |
2319 | /* print a human-readable message describing the error if available */ |
2320 | nss_print_error_message(conn->data, err); |
2321 | |
2322 | *curlcode = (is_cc_error(err)) |
2323 | ? CURLE_SSL_CERTPROBLEM |
2324 | : CURLE_RECV_ERROR; |
2325 | } |
2326 | |
2327 | return -1; |
2328 | } |
2329 | |
2330 | return nread; |
2331 | } |
2332 | |
2333 | static size_t Curl_nss_version(char *buffer, size_t size) |
2334 | { |
2335 | return msnprintf(buffer, size, "NSS/%s" , NSS_VERSION); |
2336 | } |
2337 | |
2338 | /* data might be NULL */ |
2339 | static int Curl_nss_seed(struct Curl_easy *data) |
2340 | { |
2341 | /* make sure that NSS is initialized */ |
2342 | return !!Curl_nss_force_init(data); |
2343 | } |
2344 | |
2345 | /* data might be NULL */ |
2346 | static CURLcode Curl_nss_random(struct Curl_easy *data, |
2347 | unsigned char *entropy, |
2348 | size_t length) |
2349 | { |
2350 | Curl_nss_seed(data); /* Initiate the seed if not already done */ |
2351 | |
2352 | if(SECSuccess != PK11_GenerateRandom(entropy, curlx_uztosi(length))) |
2353 | /* signal a failure */ |
2354 | return CURLE_FAILED_INIT; |
2355 | |
2356 | return CURLE_OK; |
2357 | } |
2358 | |
2359 | static CURLcode Curl_nss_md5sum(unsigned char *tmp, /* input */ |
2360 | size_t tmplen, |
2361 | unsigned char *md5sum, /* output */ |
2362 | size_t md5len) |
2363 | { |
2364 | PK11Context *MD5pw = PK11_CreateDigestContext(SEC_OID_MD5); |
2365 | unsigned int MD5out; |
2366 | |
2367 | PK11_DigestOp(MD5pw, tmp, curlx_uztoui(tmplen)); |
2368 | PK11_DigestFinal(MD5pw, md5sum, &MD5out, curlx_uztoui(md5len)); |
2369 | PK11_DestroyContext(MD5pw, PR_TRUE); |
2370 | |
2371 | return CURLE_OK; |
2372 | } |
2373 | |
2374 | static CURLcode Curl_nss_sha256sum(const unsigned char *tmp, /* input */ |
2375 | size_t tmplen, |
2376 | unsigned char *sha256sum, /* output */ |
2377 | size_t sha256len) |
2378 | { |
2379 | PK11Context *SHA256pw = PK11_CreateDigestContext(SEC_OID_SHA256); |
2380 | unsigned int SHA256out; |
2381 | |
2382 | PK11_DigestOp(SHA256pw, tmp, curlx_uztoui(tmplen)); |
2383 | PK11_DigestFinal(SHA256pw, sha256sum, &SHA256out, curlx_uztoui(sha256len)); |
2384 | PK11_DestroyContext(SHA256pw, PR_TRUE); |
2385 | |
2386 | return CURLE_OK; |
2387 | } |
2388 | |
2389 | static bool Curl_nss_cert_status_request(void) |
2390 | { |
2391 | #ifdef SSL_ENABLE_OCSP_STAPLING |
2392 | return TRUE; |
2393 | #else |
2394 | return FALSE; |
2395 | #endif |
2396 | } |
2397 | |
2398 | static bool Curl_nss_false_start(void) |
2399 | { |
2400 | #if NSSVERNUM >= 0x030f04 /* 3.15.4 */ |
2401 | return TRUE; |
2402 | #else |
2403 | return FALSE; |
2404 | #endif |
2405 | } |
2406 | |
2407 | static void *Curl_nss_get_internals(struct ssl_connect_data *connssl, |
2408 | CURLINFO info UNUSED_PARAM) |
2409 | { |
2410 | (void)info; |
2411 | return BACKEND->handle; |
2412 | } |
2413 | |
2414 | const struct Curl_ssl Curl_ssl_nss = { |
2415 | { CURLSSLBACKEND_NSS, "nss" }, /* info */ |
2416 | |
2417 | SSLSUPP_CA_PATH | |
2418 | SSLSUPP_CERTINFO | |
2419 | SSLSUPP_PINNEDPUBKEY | |
2420 | SSLSUPP_HTTPS_PROXY, |
2421 | |
2422 | sizeof(struct ssl_backend_data), |
2423 | |
2424 | Curl_nss_init, /* init */ |
2425 | Curl_nss_cleanup, /* cleanup */ |
2426 | Curl_nss_version, /* version */ |
2427 | Curl_nss_check_cxn, /* check_cxn */ |
2428 | /* NSS has no shutdown function provided and thus always fail */ |
2429 | Curl_none_shutdown, /* shutdown */ |
2430 | Curl_none_data_pending, /* data_pending */ |
2431 | Curl_nss_random, /* random */ |
2432 | Curl_nss_cert_status_request, /* cert_status_request */ |
2433 | Curl_nss_connect, /* connect */ |
2434 | Curl_nss_connect_nonblocking, /* connect_nonblocking */ |
2435 | Curl_nss_get_internals, /* get_internals */ |
2436 | Curl_nss_close, /* close_one */ |
2437 | Curl_none_close_all, /* close_all */ |
2438 | /* NSS has its own session ID cache */ |
2439 | Curl_none_session_free, /* session_free */ |
2440 | Curl_none_set_engine, /* set_engine */ |
2441 | Curl_none_set_engine_default, /* set_engine_default */ |
2442 | Curl_none_engines_list, /* engines_list */ |
2443 | Curl_nss_false_start, /* false_start */ |
2444 | Curl_nss_md5sum, /* md5sum */ |
2445 | Curl_nss_sha256sum /* sha256sum */ |
2446 | }; |
2447 | |
2448 | #endif /* USE_NSS */ |
2449 | |