Http.cpp 10 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252
  1. //---------------------------------------------------------------------------
  2. #include <vcl.h>
  3. #pragma hdrstop
  4. #include "Http.h"
  5. #include "NeonIntf.h"
  6. #include "Exceptions.h"
  7. #include "ne_request.h"
  8. #include "TextsCore.h"
  9. #include <openssl/ssl.h>
  10. //---------------------------------------------------------------------------
  11. THttp::THttp()
  12. {
  13. FProxyPort = 0;
  14. FOnDownload = NULL;
  15. FResponseLimit = -1;
  16. FRequestHeaders = NULL;
  17. FResponseHeaders = new TStringList();
  18. }
  19. //---------------------------------------------------------------------------
  20. THttp::~THttp()
  21. {
  22. delete FResponseHeaders;
  23. }
  24. //---------------------------------------------------------------------------
  25. void THttp::SendRequest(const char * Method, const UnicodeString & Request)
  26. {
  27. std::unique_ptr<TStringList> AttemptedUrls(CreateSortedStringList());
  28. AttemptedUrls->Add(URL);
  29. UnicodeString RequestUrl = URL;
  30. bool WasTlsUri = false; // shut up
  31. bool Retry;
  32. do
  33. {
  34. ne_uri uri;
  35. NeonParseUrl(RequestUrl, uri);
  36. bool IsTls = IsTlsUri(uri);
  37. if (RequestUrl == URL)
  38. {
  39. WasTlsUri = IsTls;
  40. }
  41. else
  42. {
  43. if (!IsTls && WasTlsUri)
  44. {
  45. throw Exception(LoadStr(UNENCRYPTED_REDIRECT));
  46. }
  47. }
  48. FHostName = StrFromNeon(uri.host);
  49. UnicodeString Uri = StrFromNeon(uri.path);
  50. if (uri.query != NULL)
  51. {
  52. Uri += L"?" + StrFromNeon(uri.query);
  53. }
  54. FResponse.SetLength(0);
  55. FCertificateError.SetLength(0);
  56. FException.reset(NULL);
  57. TProxyMethod ProxyMethod = ProxyHost.IsEmpty() ? ::pmNone : pmHTTP;
  58. ne_session_s * NeonSession =
  59. CreateNeonSession(
  60. uri, ProxyMethod, ProxyHost, ProxyPort, UnicodeString(), UnicodeString());
  61. try
  62. {
  63. if (IsTls)
  64. {
  65. SetNeonTlsInit(NeonSession, InitSslSession);
  66. ne_ssl_set_verify(NeonSession, NeonServerSSLCallback, this);
  67. ne_ssl_trust_default_ca(NeonSession);
  68. }
  69. ne_request_s * NeonRequest = ne_request_create(NeonSession, Method, StrToNeon(Uri));
  70. try
  71. {
  72. if (FRequestHeaders != NULL)
  73. {
  74. for (int Index = 0; Index < FRequestHeaders->Count; Index++)
  75. {
  76. ne_add_request_header(
  77. NeonRequest, StrToNeon(FRequestHeaders->Names[Index]), StrToNeon(FRequestHeaders->Values[Index]));
  78. }
  79. }
  80. UTF8String RequestUtf;
  81. if (!Request.IsEmpty())
  82. {
  83. RequestUtf = UTF8String(Request);
  84. ne_set_request_body_buffer(NeonRequest, RequestUtf.c_str(), RequestUtf.Length());
  85. }
  86. ne_add_response_body_reader(NeonRequest, ne_accept_2xx, NeonBodyReader, this);
  87. int Status = ne_request_dispatch(NeonRequest);
  88. // Exception has precedence over status as status will always be NE_ERROR,
  89. // as we returned 1 from NeonBodyReader
  90. if (FException.get() != NULL)
  91. {
  92. RethrowException(FException.get());
  93. }
  94. if (Status == NE_REDIRECT)
  95. {
  96. Retry = true;
  97. RequestUrl = GetNeonRedirectUrl(NeonSession);
  98. CheckRedirectLoop(RequestUrl, AttemptedUrls.get());
  99. }
  100. else
  101. {
  102. Retry = false;
  103. CheckNeonStatus(NeonSession, Status, FHostName, FCertificateError);
  104. const ne_status * NeonStatus = ne_get_status(NeonRequest);
  105. if (NeonStatus->klass != 2)
  106. {
  107. throw Exception(FMTLOAD(HTTP_ERROR, (NeonStatus->code, StrFromNeon(NeonStatus->reason_phrase), FHostName)));
  108. }
  109. void * Cursor = NULL;
  110. const char * HeaderName;
  111. const char * HeaderValue;
  112. while ((Cursor = ne_response_header_iterate(NeonRequest, Cursor, &HeaderName, &HeaderValue)) != NULL)
  113. {
  114. FResponseHeaders->Values[StrFromNeon(HeaderName)] = StrFromNeon(HeaderValue);
  115. }
  116. }
  117. }
  118. __finally
  119. {
  120. ne_request_destroy(NeonRequest);
  121. }
  122. }
  123. __finally
  124. {
  125. DestroyNeonSession(NeonSession);
  126. ne_uri_free(&uri);
  127. }
  128. }
  129. while (Retry);
  130. }
  131. //---------------------------------------------------------------------------
  132. void THttp::Get()
  133. {
  134. SendRequest("GET", UnicodeString());
  135. }
  136. //---------------------------------------------------------------------------
  137. void THttp::Post(const UnicodeString & Request)
  138. {
  139. SendRequest("POST", Request);
  140. }
  141. //---------------------------------------------------------------------------
  142. UnicodeString THttp::GetResponse()
  143. {
  144. UTF8String UtfResponse(FResponse);
  145. return UnicodeString(UtfResponse);
  146. }
  147. //---------------------------------------------------------------------------
  148. int THttp::NeonBodyReaderImpl(const char * Buf, size_t Len)
  149. {
  150. bool Result = true;
  151. if ((FResponseLimit < 0) ||
  152. (FResponse.Length() + Len <= FResponseLimit))
  153. {
  154. FResponse += RawByteString(Buf, Len);
  155. if (FOnDownload != NULL)
  156. {
  157. bool Cancel = false;
  158. try
  159. {
  160. FOnDownload(this, ResponseLength, Cancel);
  161. }
  162. catch (Exception & E)
  163. {
  164. FException.reset(CloneException(&E));
  165. Result = false;
  166. }
  167. if (Cancel)
  168. {
  169. FException.reset(new EAbort(UnicodeString()));
  170. Result = false;
  171. }
  172. }
  173. }
  174. // neon wants 0 for success
  175. return Result ? 0 : 1;
  176. }
  177. //---------------------------------------------------------------------------
  178. int THttp::NeonBodyReader(void * UserData, const char * Buf, size_t Len)
  179. {
  180. THttp * Http = static_cast<THttp *>(UserData);
  181. return Http->NeonBodyReaderImpl(Buf, Len);
  182. }
  183. //---------------------------------------------------------------------------
  184. __int64 THttp::GetResponseLength()
  185. {
  186. return FResponse.Length();
  187. }
  188. //------------------------------------------------------------------------------
  189. void THttp::InitSslSession(ssl_st * Ssl, ne_session * /*Session*/)
  190. {
  191. int Options = SSL_OP_NO_SSLv2 | SSL_OP_NO_SSLv3 | SSL_OP_NO_TLSv1 | SSL_OP_NO_TLSv1_1;
  192. SSL_ctrl(Ssl, SSL_CTRL_OPTIONS, Options, NULL);
  193. }
  194. //---------------------------------------------------------------------------
  195. int THttp::NeonServerSSLCallback(void * UserData, int Failures, const ne_ssl_certificate * Certificate)
  196. {
  197. THttp * Http = static_cast<THttp *>(UserData);
  198. return Http->NeonServerSSLCallbackImpl(Failures, Certificate);
  199. }
  200. //---------------------------------------------------------------------------
  201. int THttp::NeonServerSSLCallbackImpl(int Failures, const ne_ssl_certificate * Certificate)
  202. {
  203. AnsiString AsciiCert = NeonExportCertificate(Certificate);
  204. // winscp.net 31.05.2015 - 02.06.2016
  205. const AnsiString WebCert = "MIIEqzCCA5OgAwIBAgIDBMLgMA0GCSqGSIb3DQEBCwUAMEcxCzAJBgNVBAYTAlVTMRYwFAYDVQQKEw1HZW9UcnVzdCBJbmMuMSAwHgYDVQQDExdSYXBpZFNTTCBTSEEyNTYgQ0EgLSBHMzAeFw0xNTA1MzEwMDA1NTRaFw0xNjA2MDIwNTUxNTNaMIGSMRMwEQYDVQQLEwpHVDUyNTA2NDcyMTEwLwYDVQQLEyhTZWUgd3d3LnJhcGlkc3NsLmNvbS9yZXNvdXJjZXMvY3BzIChjKTE1MS8wLQYDVQQLEyZEb21haW4gQ29udHJvbCBWYWxpZGF0ZWQgLSBSYXBpZFNTTChSKTEXMBUGA1UEAxMOd3d3LndpbnNjcC5uZXQwggEiMA0GCSqGSIb3DQEBAQUAA4IBDwAwggEKAoIBAQDRHP+5FLE+q+oeu0Qlx2eX1nV8Vc0jOkwam95Vr6JV9Ar5ZZIbR8a/jBJv/tDlQ8nvx38gPoFCcPX3qBjRhxIBuNETbLi+7Yd69CXyZKNrbo0pxAbn5C/JKFgog5EkSdR65gia0J6YGPDw/iq180MpkNIBAFInq8Pc36hLz4jrAunFjxJ18pkmBlOVSr7/4Ppd15Co9fhF4A3QI2wcrAOjEfGhssfk7aRp8x36/GI3rs/Or1SbO6/ZSg9h7a5uvJFgQPDVRmqytd03EC9HLVOvRK/70gcQfYcOSEWkEkEO8jQ7eXv0u1y5E20Te0Zk9hVXll2RpCO8u5RyyzhSKW1DAgMBAAGjggFSMIIBTjAfBgNVHSMEGDAWgBTDnPP800YINLvORn+gfFvz4gjLWTBXBggrBgEFBQcBAQRLMEkwHwYIKwYBBQUHMAGGE2h0dHA6Ly9ndi5zeW1jZC5jb20wJgYIKwYBBQUHMAKGGmh0dHA6Ly9ndi5zeW1jYi5jb20vZ3YuY3J0MA4GA1UdDwEB/wQEAwIFoDAdBgNVHSUEFjAUBggrBgEFBQcDAQYIKwYBBQUHAwIwJQYDVR0RBB4wHIIOd3d3LndpbnNjcC5uZXSCCndpbnNjcC5uZXQwKwYDVR0fBCQwIjAgoB6gHIYaaHR0cDovL2d2LnN5bWNiLmNvbS9ndi5jcmwwDAYDVR0TAQH/BAIwADBBBgNVHSAEOjA4MDYGBmeBDAECATAsMCoGCCsGAQUFBwIBFh5odHRwczovL3d3dy5yYXBpZHNzbC5jb20vbGVnYWwwDQYJKoZIhvcNAQELBQADggEBAHzQ0JNQOtaYUbcw6OCyyiV5O5VemJSDagD5VG5W2gkLfxa9v1ly9hxbdlkKv4d9ruq36ZiHxqKBLoBzw68RNOG/CFY85Xam5Wygo8afSIuhLOYgSUMriH8aoBUXssG15t54z1em58Qh5xMp0crQAbY7D4opo0pEzkaTaS8ulwOxu5SSpK3DF12VKUdKhBs7T0QY+oOJZsqkx7GdmeKxoKRpBQvnRegCszR7vkdWsY0fFZHeNdThkY1iRxI6b4tyDYgZ0COj8WXCBia9wZm/czMmq/d7KED2V06w3Ttc4hDOHl+Onm/gQFLs++1f2Z/X6iPNhIEMNKKH51y/eHJQMxE=";
  206. // cdn.winscp.net 02.06.2015 - 04.06.2016
  207. const AnsiString CdnCert = "MIIEnzCCA4egAwIBAgIDBMxPMA0GCSqGSIb3DQEBCwUAMEcxCzAJBgNVBAYTAlVTMRYwFAYDVQQKEw1HZW9UcnVzdCBJbmMuMSAwHgYDVQQDExdSYXBpZFNTTCBTSEEyNTYgQ0EgLSBHMzAeFw0xNTA2MDIwNjIzMDFaFw0xNjA2MDQwMDU0NTVaMIGSMRMwEQYDVQQLEwpHVDUwMzQ0NzgyMTEwLwYDVQQLEyhTZWUgd3d3LnJhcGlkc3NsLmNvbS9yZXNvdXJjZXMvY3BzIChjKTE1MS8wLQYDVQQLEyZEb21haW4gQ29udHJvbCBWYWxpZGF0ZWQgLSBSYXBpZFNTTChSKTEXMBUGA1UEAxMOY2RuLndpbnNjcC5uZXQwggEiMA0GCSqGSIb3DQEBAQUAA4IBDwAwggEKAoIBAQC5ykjjmhjnd6hMmb7WNlQwSzjGCiLA3b+U2xfUYGsR+0o8frU3bv50vNp+IlTFXn32Qt3QtskuoLdi/nip0ABBtgEUt4FAoZ/AMKPyT0hD95ZEFlaclCzUANmSJswWdQIZltbLulMAqt618Snkog3Z3nkjzAMZuKvEYvPV9ujuM2kzkWZr0/OoPHINUkaI6mZwTxCvxwmazBtyIx5tXqmfiOJ1R+viAZm4Av5nqaXz1dTqSjrgpvFtwkTu8YQpK3qrpjN+H67PnClOAS1GY0oaSMccxq0bYL1w0hORa+NyQ+ZTIiXVwiXFJ0w23qHadaoKOiG8WnQ49YvCpbDhMU+3AgMBAAGjggFGMIIBQjAfBgNVHSMEGDAWgBTDnPP800YINLvORn+gfFvz4gjLWTBXBggrBgEFBQcBAQRLMEkwHwYIKwYBBQUHMAGGE2h0dHA6Ly9ndi5zeW1jZC5jb20wJgYIKwYBBQUHMAKGGmh0dHA6Ly9ndi5zeW1jYi5jb20vZ3YuY3J0MA4GA1UdDwEB/wQEAwIFoDAdBgNVHSUEFjAUBggrBgEFBQcDAQYIKwYBBQUHAwIwGQYDVR0RBBIwEIIOY2RuLndpbnNjcC5uZXQwKwYDVR0fBCQwIjAgoB6gHIYaaHR0cDovL2d2LnN5bWNiLmNvbS9ndi5jcmwwDAYDVR0TAQH/BAIwADBBBgNVHSAEOjA4MDYGBmeBDAECATAsMCoGCCsGAQUFBwIBFh5odHRwczovL3d3dy5yYXBpZHNzbC5jb20vbGVnYWwwDQYJKoZIhvcNAQELBQADggEBAF9BN1+whMrK/HCDggLi/76+zDkzqVvNjdTgOLLSBCZaTJV1xNwIfxrPVwECEKkqV0D3eYx53aMxudVq+QuQ7VlS2k0Nu12Bfr0LFcUIOOO55jfjXUnJ8QLWoZQIJ6spOk0Bilxos4yzcORxOfASjkECEg1XUK3THnNgVLKZS92JSdxzsRkZvkpKCSNlX4ftoaPyDsgYWv0gBBA4RPAjAJB5qQTUeu0xIO/r1IhqLqnhlnJ3ewE68ScHbE5sMpl5RLEiaVRBeNw/whVEDPe2TY+JNzk6NdsGWq6uPCFsCXTGzX2QkAwR+rk2y4PPoY2vnj2cQoYWXF5pBjpMPYyRu8Q=";
  208. if ((AsciiCert == WebCert) ||
  209. (AsciiCert == CdnCert))
  210. {
  211. Failures &= ~NE_SSL_UNTRUSTED;
  212. }
  213. if (Failures != 0)
  214. {
  215. NeonWindowsValidateCertificate(Failures, AsciiCert);
  216. }
  217. if (Failures != 0)
  218. {
  219. FCertificateError = NeonCertificateFailuresErrorStr(Failures, FHostName);
  220. }
  221. return (Failures == 0) ? NE_OK : NE_ERROR;
  222. }
  223. //---------------------------------------------------------------------------