ConnectionFromClient.cpp 24 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662
  1. /*
  2. * Copyright (c) 2018-2024, Andreas Kling <andreas@ladybird.org>
  3. *
  4. * SPDX-License-Identifier: BSD-2-Clause
  5. */
  6. #include <AK/Badge.h>
  7. #include <AK/IDAllocator.h>
  8. #include <AK/NonnullOwnPtr.h>
  9. #include <LibCore/EventLoop.h>
  10. #include <LibCore/Proxy.h>
  11. #include <LibCore/Socket.h>
  12. #include <LibRequests/NetworkErrorEnum.h>
  13. #include <LibTextCodec/Decoder.h>
  14. #include <LibWebSocket/ConnectionInfo.h>
  15. #include <LibWebSocket/Message.h>
  16. #include <RequestServer/ConnectionFromClient.h>
  17. #include <RequestServer/RequestClientEndpoint.h>
  18. #include <curl/curl.h>
  19. namespace RequestServer {
  20. ByteString g_default_certificate_path;
  21. static HashMap<int, RefPtr<ConnectionFromClient>> s_connections;
  22. static IDAllocator s_client_ids;
  23. static long s_connect_timeout_seconds = 90L;
  24. static HashMap<ByteString, ByteString> g_dns_cache; // host -> curl "resolve" string
  25. static struct {
  26. Optional<Core::SocketAddress> server_address;
  27. Optional<ByteString> server_hostname;
  28. u16 port;
  29. bool use_dns_over_tls = true;
  30. } g_dns_info;
  31. static WeakPtr<Resolver> s_resolver {};
  32. static NonnullRefPtr<Resolver> default_resolver()
  33. {
  34. if (auto resolver = s_resolver.strong_ref())
  35. return *resolver;
  36. auto resolver = make_ref_counted<Resolver>([] -> ErrorOr<DNS::Resolver::SocketResult> {
  37. if (!g_dns_info.server_address.has_value()) {
  38. if (!g_dns_info.server_hostname.has_value())
  39. return Error::from_string_literal("No DNS server configured");
  40. auto resolved = TRY(default_resolver()->dns.lookup(*g_dns_info.server_hostname)->await());
  41. if (resolved->cached_addresses().is_empty())
  42. return Error::from_string_literal("Failed to resolve DNS server hostname");
  43. auto address = resolved->cached_addresses().first().visit([](auto& addr) -> Core::SocketAddress { return { addr, g_dns_info.port }; });
  44. g_dns_info.server_address = address;
  45. }
  46. if (g_dns_info.use_dns_over_tls) {
  47. return DNS::Resolver::SocketResult {
  48. MaybeOwned<Core::Socket>(TRY(TLS::TLSv12::connect(*g_dns_info.server_address, *g_dns_info.server_hostname))),
  49. DNS::Resolver::ConnectionMode::TCP,
  50. };
  51. }
  52. return DNS::Resolver::SocketResult {
  53. MaybeOwned<Core::Socket>(TRY(Core::BufferedSocket<Core::UDPSocket>::create(TRY(Core::UDPSocket::connect(*g_dns_info.server_address))))),
  54. DNS::Resolver::ConnectionMode::UDP,
  55. };
  56. });
  57. s_resolver = resolver;
  58. return resolver;
  59. }
  60. struct ConnectionFromClient::ActiveRequest {
  61. CURLM* multi { nullptr };
  62. CURL* easy { nullptr };
  63. i32 request_id { 0 };
  64. RefPtr<Core::Notifier> notifier;
  65. WeakPtr<ConnectionFromClient> client;
  66. int writer_fd { 0 };
  67. HTTP::HeaderMap headers;
  68. bool got_all_headers { false };
  69. bool is_connect_only { false };
  70. size_t downloaded_so_far { 0 };
  71. String url;
  72. Optional<String> reason_phrase;
  73. ByteBuffer body;
  74. ActiveRequest(ConnectionFromClient& client, CURLM* multi, CURL* easy, i32 request_id, int writer_fd)
  75. : multi(multi)
  76. , easy(easy)
  77. , request_id(request_id)
  78. , client(client)
  79. , writer_fd(writer_fd)
  80. {
  81. }
  82. ~ActiveRequest()
  83. {
  84. if (writer_fd > 0)
  85. MUST(Core::System::close(writer_fd));
  86. auto result = curl_multi_remove_handle(multi, easy);
  87. VERIFY(result == CURLM_OK);
  88. curl_easy_cleanup(easy);
  89. }
  90. void flush_headers_if_needed()
  91. {
  92. if (got_all_headers)
  93. return;
  94. got_all_headers = true;
  95. long http_status_code = 0;
  96. auto result = curl_easy_getinfo(easy, CURLINFO_RESPONSE_CODE, &http_status_code);
  97. VERIFY(result == CURLE_OK);
  98. client->async_headers_became_available(request_id, headers, http_status_code, reason_phrase);
  99. }
  100. };
  101. size_t ConnectionFromClient::on_header_received(void* buffer, size_t size, size_t nmemb, void* user_data)
  102. {
  103. auto* request = static_cast<ActiveRequest*>(user_data);
  104. size_t total_size = size * nmemb;
  105. auto header_line = StringView { static_cast<char const*>(buffer), total_size };
  106. // NOTE: We need to extract the HTTP reason phrase since it can be a custom value.
  107. // Fetching infrastructure needs this value for setting the status message.
  108. if (!request->reason_phrase.has_value() && header_line.starts_with("HTTP/"sv)) {
  109. if (auto const space_positions = header_line.find_all(" "sv); space_positions.size() > 1) {
  110. auto const second_space_offset = space_positions.at(1);
  111. auto const reason_phrase_string_view = header_line.substring_view(second_space_offset + 1).trim_whitespace();
  112. if (!reason_phrase_string_view.is_empty()) {
  113. auto decoder = TextCodec::decoder_for_exact_name("ISO-8859-1"sv);
  114. VERIFY(decoder.has_value());
  115. request->reason_phrase = MUST(decoder->to_utf8(reason_phrase_string_view));
  116. return total_size;
  117. }
  118. }
  119. }
  120. if (auto colon_index = header_line.find(':'); colon_index.has_value()) {
  121. auto name = header_line.substring_view(0, colon_index.value()).trim_whitespace();
  122. auto value = header_line.substring_view(colon_index.value() + 1, header_line.length() - colon_index.value() - 1).trim_whitespace();
  123. request->headers.set(name, value);
  124. }
  125. return total_size;
  126. }
  127. size_t ConnectionFromClient::on_data_received(void* buffer, size_t size, size_t nmemb, void* user_data)
  128. {
  129. auto* request = static_cast<ActiveRequest*>(user_data);
  130. request->flush_headers_if_needed();
  131. size_t total_size = size * nmemb;
  132. size_t remaining_length = total_size;
  133. u8 const* remaining_data = static_cast<u8 const*>(buffer);
  134. while (remaining_length > 0) {
  135. auto result = Core::System::write(request->writer_fd, { remaining_data, remaining_length });
  136. if (result.is_error()) {
  137. if (result.error().code() != EAGAIN) {
  138. dbgln("on_data_received: write failed: {}", result.error());
  139. VERIFY_NOT_REACHED();
  140. }
  141. sched_yield();
  142. continue;
  143. }
  144. auto nwritten = result.value();
  145. if (nwritten == 0) {
  146. dbgln("on_data_received: write returned 0");
  147. VERIFY_NOT_REACHED();
  148. }
  149. remaining_data += nwritten;
  150. remaining_length -= nwritten;
  151. }
  152. Optional<u64> content_length_for_ipc;
  153. curl_off_t content_length = -1;
  154. auto res = curl_easy_getinfo(request->easy, CURLINFO_CONTENT_LENGTH_DOWNLOAD_T, &content_length);
  155. if (res == CURLE_OK && content_length != -1) {
  156. content_length_for_ipc = content_length;
  157. }
  158. request->downloaded_so_far += total_size;
  159. return total_size;
  160. }
  161. int ConnectionFromClient::on_socket_callback(CURL*, int sockfd, int what, void* user_data, void*)
  162. {
  163. auto* client = static_cast<ConnectionFromClient*>(user_data);
  164. if (what == CURL_POLL_REMOVE) {
  165. client->m_read_notifiers.remove(sockfd);
  166. client->m_write_notifiers.remove(sockfd);
  167. return 0;
  168. }
  169. if (what & CURL_POLL_IN) {
  170. client->m_read_notifiers.ensure(sockfd, [client, sockfd, multi = client->m_curl_multi] {
  171. auto notifier = Core::Notifier::construct(sockfd, Core::NotificationType::Read);
  172. notifier->on_activation = [client, sockfd, multi] {
  173. int still_running = 0;
  174. auto result = curl_multi_socket_action(multi, sockfd, CURL_CSELECT_IN, &still_running);
  175. VERIFY(result == CURLM_OK);
  176. client->check_active_requests();
  177. };
  178. notifier->set_enabled(true);
  179. return notifier;
  180. });
  181. }
  182. if (what & CURL_POLL_OUT) {
  183. client->m_write_notifiers.ensure(sockfd, [client, sockfd, multi = client->m_curl_multi] {
  184. auto notifier = Core::Notifier::construct(sockfd, Core::NotificationType::Write);
  185. notifier->on_activation = [client, sockfd, multi] {
  186. int still_running = 0;
  187. auto result = curl_multi_socket_action(multi, sockfd, CURL_CSELECT_OUT, &still_running);
  188. VERIFY(result == CURLM_OK);
  189. client->check_active_requests();
  190. };
  191. notifier->set_enabled(true);
  192. return notifier;
  193. });
  194. }
  195. return 0;
  196. }
  197. int ConnectionFromClient::on_timeout_callback(void*, long timeout_ms, void* user_data)
  198. {
  199. auto* client = static_cast<ConnectionFromClient*>(user_data);
  200. if (!client->m_timer)
  201. return 0;
  202. if (timeout_ms < 0) {
  203. client->m_timer->stop();
  204. } else {
  205. client->m_timer->restart(timeout_ms);
  206. }
  207. return 0;
  208. }
  209. ConnectionFromClient::ConnectionFromClient(IPC::Transport transport)
  210. : IPC::ConnectionFromClient<RequestClientEndpoint, RequestServerEndpoint>(*this, move(transport), s_client_ids.allocate())
  211. , m_resolver(default_resolver())
  212. {
  213. s_connections.set(client_id(), *this);
  214. m_curl_multi = curl_multi_init();
  215. auto set_option = [this](auto option, auto value) {
  216. auto result = curl_multi_setopt(m_curl_multi, option, value);
  217. VERIFY(result == CURLM_OK);
  218. };
  219. set_option(CURLMOPT_SOCKETFUNCTION, &on_socket_callback);
  220. set_option(CURLMOPT_SOCKETDATA, this);
  221. set_option(CURLMOPT_TIMERFUNCTION, &on_timeout_callback);
  222. set_option(CURLMOPT_TIMERDATA, this);
  223. m_timer = Core::Timer::create_single_shot(0, [this] {
  224. int still_running = 0;
  225. auto result = curl_multi_socket_action(m_curl_multi, CURL_SOCKET_TIMEOUT, 0, &still_running);
  226. VERIFY(result == CURLM_OK);
  227. check_active_requests();
  228. });
  229. }
  230. ConnectionFromClient::~ConnectionFromClient()
  231. {
  232. }
  233. void ConnectionFromClient::die()
  234. {
  235. auto client_id = this->client_id();
  236. s_connections.remove(client_id);
  237. s_client_ids.deallocate(client_id);
  238. if (s_connections.is_empty())
  239. Core::EventLoop::current().quit(0);
  240. }
  241. Messages::RequestServer::ConnectNewClientResponse ConnectionFromClient::connect_new_client()
  242. {
  243. static_assert(IsSame<IPC::Transport, IPC::TransportSocket>, "Need to handle other IPC transports here");
  244. int socket_fds[2] {};
  245. if (auto err = Core::System::socketpair(AF_LOCAL, SOCK_STREAM, 0, socket_fds); err.is_error()) {
  246. dbgln("Failed to create client socketpair: {}", err.error());
  247. return IPC::File {};
  248. }
  249. auto client_socket_or_error = Core::LocalSocket::adopt_fd(socket_fds[0]);
  250. if (client_socket_or_error.is_error()) {
  251. close(socket_fds[0]);
  252. close(socket_fds[1]);
  253. dbgln("Failed to adopt client socket: {}", client_socket_or_error.error());
  254. return IPC::File {};
  255. }
  256. auto client_socket = client_socket_or_error.release_value();
  257. // Note: A ref is stored in the static s_connections map
  258. auto client = adopt_ref(*new ConnectionFromClient(IPC::Transport(move(client_socket))));
  259. return IPC::File::adopt_fd(socket_fds[1]);
  260. }
  261. Messages::RequestServer::IsSupportedProtocolResponse ConnectionFromClient::is_supported_protocol(ByteString const& protocol)
  262. {
  263. return protocol == "http"sv || protocol == "https"sv;
  264. }
  265. void ConnectionFromClient::set_dns_server(ByteString const& host_or_address, u16 port, bool use_tls)
  266. {
  267. if (host_or_address == g_dns_info.server_hostname && port == g_dns_info.port && use_tls == g_dns_info.use_dns_over_tls)
  268. return;
  269. auto result = [&] -> ErrorOr<void> {
  270. Core::SocketAddress addr;
  271. if (auto v4 = IPv4Address::from_string(host_or_address); v4.has_value())
  272. addr = { v4.value(), port };
  273. else if (auto v6 = IPv6Address::from_string(host_or_address); v6.has_value())
  274. addr = { v6.value(), port };
  275. else
  276. TRY(default_resolver()->dns.lookup(host_or_address)->await())->cached_addresses().first().visit([&](auto& address) { addr = { address, port }; });
  277. g_dns_info.server_address = addr;
  278. g_dns_info.server_hostname = host_or_address;
  279. g_dns_info.port = port;
  280. g_dns_info.use_dns_over_tls = use_tls;
  281. return {};
  282. }();
  283. if (result.is_error())
  284. dbgln("Failed to set DNS server: {}", result.error());
  285. else
  286. default_resolver()->dns.reset_connection();
  287. }
  288. void ConnectionFromClient::start_request(i32 request_id, ByteString const& method, URL::URL const& url, HTTP::HeaderMap const& request_headers, ByteBuffer const& request_body, Core::ProxyData const& proxy_data)
  289. {
  290. if (!url.is_valid()) {
  291. dbgln("StartRequest: Invalid URL requested: '{}'", url);
  292. async_request_finished(request_id, 0, Requests::NetworkError::MalformedUrl);
  293. return;
  294. }
  295. auto host = url.serialized_host().value().to_byte_string();
  296. auto dns_promise = m_resolver->dns.lookup(host, DNS::Messages::Class::IN, Array { DNS::Messages::ResourceType::A, DNS::Messages::ResourceType::AAAA }.span());
  297. auto resolve_result = dns_promise->await();
  298. if (resolve_result.is_error()) {
  299. dbgln("StartRequest: DNS lookup failed for '{}': {}", host, resolve_result.error());
  300. async_request_finished(request_id, 0, Requests::NetworkError::UnableToResolveHost);
  301. return;
  302. }
  303. auto dns_result = resolve_result.release_value();
  304. if (dns_result->records().is_empty()) {
  305. dbgln("StartRequest: DNS lookup failed for '{}'", host);
  306. async_request_finished(request_id, 0, Requests::NetworkError::UnableToResolveHost);
  307. return;
  308. }
  309. auto* easy = curl_easy_init();
  310. if (!easy) {
  311. dbgln("StartRequest: Failed to initialize curl easy handle");
  312. return;
  313. }
  314. auto fds_or_error = Core::System::pipe2(O_NONBLOCK);
  315. if (fds_or_error.is_error()) {
  316. dbgln("StartRequest: Failed to create pipe: {}", fds_or_error.error());
  317. return;
  318. }
  319. auto fds = fds_or_error.release_value();
  320. auto writer_fd = fds[1];
  321. auto reader_fd = fds[0];
  322. async_request_started(request_id, IPC::File::adopt_fd(reader_fd));
  323. auto request = make<ActiveRequest>(*this, m_curl_multi, easy, request_id, writer_fd);
  324. request->url = url.to_string().value();
  325. auto set_option = [easy](auto option, auto value) {
  326. auto result = curl_easy_setopt(easy, option, value);
  327. if (result != CURLE_OK) {
  328. dbgln("StartRequest: Failed to set curl option: {}", curl_easy_strerror(result));
  329. return false;
  330. }
  331. return true;
  332. };
  333. set_option(CURLOPT_PRIVATE, request.ptr());
  334. if (!g_default_certificate_path.is_empty())
  335. set_option(CURLOPT_CAINFO, g_default_certificate_path.characters());
  336. set_option(CURLOPT_ACCEPT_ENCODING, "gzip, deflate, br");
  337. set_option(CURLOPT_URL, url.to_string().value().to_byte_string().characters());
  338. set_option(CURLOPT_PORT, url.port_or_default());
  339. set_option(CURLOPT_CONNECTTIMEOUT, s_connect_timeout_seconds);
  340. bool did_set_body = false;
  341. if (method == "GET"sv) {
  342. set_option(CURLOPT_HTTPGET, 1L);
  343. } else if (method.is_one_of("POST"sv, "PUT"sv, "PATCH"sv, "DELETE"sv)) {
  344. request->body = request_body;
  345. set_option(CURLOPT_POSTFIELDSIZE, request->body.size());
  346. set_option(CURLOPT_POSTFIELDS, request->body.data());
  347. did_set_body = true;
  348. } else if (method == "HEAD") {
  349. set_option(CURLOPT_NOBODY, 1L);
  350. }
  351. set_option(CURLOPT_CUSTOMREQUEST, method.characters());
  352. set_option(CURLOPT_FOLLOWLOCATION, 0);
  353. struct curl_slist* curl_headers = nullptr;
  354. // NOTE: CURLOPT_POSTFIELDS automatically sets the Content-Type header.
  355. // Set it to empty if the headers passed in don't contain a content type.
  356. if (did_set_body && !request_headers.contains("Content-Type"))
  357. curl_headers = curl_slist_append(curl_headers, "Content-Type:");
  358. for (auto const& header : request_headers.headers()) {
  359. auto header_string = ByteString::formatted("{}: {}", header.name, header.value);
  360. curl_headers = curl_slist_append(curl_headers, header_string.characters());
  361. }
  362. set_option(CURLOPT_HTTPHEADER, curl_headers);
  363. // FIXME: Set up proxy if applicable
  364. (void)proxy_data;
  365. set_option(CURLOPT_WRITEFUNCTION, &on_data_received);
  366. set_option(CURLOPT_WRITEDATA, reinterpret_cast<void*>(request.ptr()));
  367. set_option(CURLOPT_HEADERFUNCTION, &on_header_received);
  368. set_option(CURLOPT_HEADERDATA, reinterpret_cast<void*>(request.ptr()));
  369. StringBuilder resolve_opt_builder;
  370. resolve_opt_builder.appendff("{}:{}:", host, url.port_or_default());
  371. auto first = true;
  372. for (auto& addr : dns_result->cached_addresses()) {
  373. auto formatted_address = addr.visit(
  374. [&](IPv4Address const& ipv4) { return ipv4.to_byte_string(); },
  375. [&](IPv6Address const& ipv6) { return MUST(ipv6.to_string()).to_byte_string(); });
  376. if (!first)
  377. resolve_opt_builder.append(',');
  378. first = false;
  379. resolve_opt_builder.append(formatted_address);
  380. }
  381. auto formatted_address = resolve_opt_builder.to_byte_string();
  382. g_dns_cache.set(host, formatted_address);
  383. curl_slist* resolve_list = curl_slist_append(nullptr, formatted_address.characters());
  384. curl_easy_setopt(easy, CURLOPT_RESOLVE, resolve_list);
  385. auto result = curl_multi_add_handle(m_curl_multi, easy);
  386. VERIFY(result == CURLM_OK);
  387. m_active_requests.set(request_id, move(request));
  388. }
  389. static Requests::NetworkError map_curl_code_to_network_error(CURLcode const& code)
  390. {
  391. switch (code) {
  392. case CURLE_COULDNT_RESOLVE_HOST:
  393. return Requests::NetworkError::UnableToResolveHost;
  394. case CURLE_COULDNT_RESOLVE_PROXY:
  395. return Requests::NetworkError::UnableToResolveProxy;
  396. case CURLE_COULDNT_CONNECT:
  397. return Requests::NetworkError::UnableToConnect;
  398. case CURLE_OPERATION_TIMEDOUT:
  399. return Requests::NetworkError::TimeoutReached;
  400. case CURLE_TOO_MANY_REDIRECTS:
  401. return Requests::NetworkError::TooManyRedirects;
  402. case CURLE_SSL_CONNECT_ERROR:
  403. return Requests::NetworkError::SSLHandshakeFailed;
  404. case CURLE_PEER_FAILED_VERIFICATION:
  405. return Requests::NetworkError::SSLVerificationFailed;
  406. case CURLE_URL_MALFORMAT:
  407. return Requests::NetworkError::MalformedUrl;
  408. default:
  409. return Requests::NetworkError::Unknown;
  410. }
  411. }
  412. void ConnectionFromClient::check_active_requests()
  413. {
  414. int msgs_in_queue = 0;
  415. while (auto* msg = curl_multi_info_read(m_curl_multi, &msgs_in_queue)) {
  416. if (msg->msg != CURLMSG_DONE)
  417. continue;
  418. ActiveRequest* request = nullptr;
  419. auto result = curl_easy_getinfo(msg->easy_handle, CURLINFO_PRIVATE, &request);
  420. VERIFY(result == CURLE_OK);
  421. if (!request->is_connect_only) {
  422. request->flush_headers_if_needed();
  423. auto result_code = msg->data.result;
  424. Optional<Requests::NetworkError> network_error;
  425. bool const request_was_successful = result_code == CURLE_OK;
  426. if (!request_was_successful) {
  427. network_error = map_curl_code_to_network_error(result_code);
  428. if (network_error.has_value() && network_error.value() == Requests::NetworkError::Unknown) {
  429. char const* curl_error_message = curl_easy_strerror(result_code);
  430. dbgln("ConnectionFromClient: Unable to map error ({}), message: \"\033[31;1m{}\033[0m\"", static_cast<int>(result_code), curl_error_message);
  431. }
  432. }
  433. async_request_finished(request->request_id, request->downloaded_so_far, network_error);
  434. }
  435. m_active_requests.remove(request->request_id);
  436. }
  437. }
  438. Messages::RequestServer::StopRequestResponse ConnectionFromClient::stop_request(i32 request_id)
  439. {
  440. auto request = m_active_requests.take(request_id);
  441. if (!request.has_value()) {
  442. dbgln("StopRequest: Request ID {} not found", request_id);
  443. return false;
  444. }
  445. return true;
  446. }
  447. void ConnectionFromClient::did_receive_headers(Badge<Request>, Request&)
  448. {
  449. }
  450. void ConnectionFromClient::did_finish_request(Badge<Request>, Request&, bool)
  451. {
  452. }
  453. void ConnectionFromClient::did_progress_request(Badge<Request>, Request&)
  454. {
  455. }
  456. void ConnectionFromClient::did_request_certificates(Badge<Request>, Request&)
  457. {
  458. TODO();
  459. }
  460. Messages::RequestServer::SetCertificateResponse ConnectionFromClient::set_certificate(i32 request_id, ByteString const& certificate, ByteString const& key)
  461. {
  462. (void)request_id;
  463. (void)certificate;
  464. (void)key;
  465. TODO();
  466. }
  467. void ConnectionFromClient::ensure_connection(URL::URL const& url, ::RequestServer::CacheLevel const& cache_level)
  468. {
  469. if (!url.is_valid()) {
  470. dbgln("EnsureConnection: Invalid URL requested: '{}'", url);
  471. return;
  472. }
  473. auto const url_string_value = url.to_string().value();
  474. if (cache_level == CacheLevel::CreateConnection) {
  475. auto* easy = curl_easy_init();
  476. if (!easy) {
  477. dbgln("EnsureConnection: Failed to initialize curl easy handle");
  478. return;
  479. }
  480. auto set_option = [easy](auto option, auto value) {
  481. auto result = curl_easy_setopt(easy, option, value);
  482. if (result != CURLE_OK) {
  483. dbgln("EnsureConnection: Failed to set curl option: {}", curl_easy_strerror(result));
  484. return false;
  485. }
  486. return true;
  487. };
  488. auto connect_only_request_id = get_random<i32>();
  489. auto request = make<ActiveRequest>(*this, m_curl_multi, easy, connect_only_request_id, 0);
  490. request->url = url_string_value;
  491. request->is_connect_only = true;
  492. set_option(CURLOPT_PRIVATE, request.ptr());
  493. set_option(CURLOPT_URL, url_string_value.to_byte_string().characters());
  494. set_option(CURLOPT_PORT, url.port_or_default());
  495. set_option(CURLOPT_CONNECTTIMEOUT, s_connect_timeout_seconds);
  496. set_option(CURLOPT_CONNECT_ONLY, 1L);
  497. auto const result = curl_multi_add_handle(m_curl_multi, easy);
  498. VERIFY(result == CURLM_OK);
  499. m_active_requests.set(connect_only_request_id, move(request));
  500. return;
  501. }
  502. if (cache_level == CacheLevel::ResolveOnly) {
  503. dbgln("FIXME: EnsureConnection: Implement ResolveOnly cache level");
  504. }
  505. }
  506. void ConnectionFromClient::websocket_connect(i64 websocket_id, URL::URL const& url, ByteString const& origin, Vector<ByteString> const& protocols, Vector<ByteString> const& extensions, HTTP::HeaderMap const& additional_request_headers)
  507. {
  508. if (!url.is_valid()) {
  509. dbgln("WebSocket::Connect: Invalid URL requested: '{}'", url);
  510. return;
  511. }
  512. WebSocket::ConnectionInfo connection_info(url);
  513. connection_info.set_origin(origin);
  514. connection_info.set_protocols(protocols);
  515. connection_info.set_extensions(extensions);
  516. connection_info.set_headers(additional_request_headers);
  517. auto connection = WebSocket::WebSocket::create(move(connection_info));
  518. connection->on_open = [this, websocket_id]() {
  519. async_websocket_connected(websocket_id);
  520. };
  521. connection->on_message = [this, websocket_id](auto message) {
  522. async_websocket_received(websocket_id, message.is_text(), message.data());
  523. };
  524. connection->on_error = [this, websocket_id](auto message) {
  525. async_websocket_errored(websocket_id, (i32)message);
  526. };
  527. connection->on_close = [this, websocket_id](u16 code, ByteString reason, bool was_clean) {
  528. async_websocket_closed(websocket_id, code, move(reason), was_clean);
  529. };
  530. connection->on_ready_state_change = [this, websocket_id](auto state) {
  531. async_websocket_ready_state_changed(websocket_id, (u32)state);
  532. };
  533. connection->start();
  534. m_websockets.set(websocket_id, move(connection));
  535. }
  536. void ConnectionFromClient::websocket_send(i64 websocket_id, bool is_text, ByteBuffer const& data)
  537. {
  538. if (auto connection = m_websockets.get(websocket_id).value_or({}); connection && connection->ready_state() == WebSocket::ReadyState::Open)
  539. connection->send(WebSocket::Message { data, is_text });
  540. }
  541. void ConnectionFromClient::websocket_close(i64 websocket_id, u16 code, ByteString const& reason)
  542. {
  543. if (auto connection = m_websockets.get(websocket_id).value_or({}); connection && connection->ready_state() == WebSocket::ReadyState::Open)
  544. connection->close(code, reason);
  545. }
  546. Messages::RequestServer::WebsocketSetCertificateResponse ConnectionFromClient::websocket_set_certificate(i64 websocket_id, ByteString const&, ByteString const&)
  547. {
  548. auto success = false;
  549. if (auto connection = m_websockets.get(websocket_id).value_or({}); connection) {
  550. // NO OP here
  551. // connection->set_certificate(certificate, key);
  552. success = true;
  553. }
  554. return success;
  555. }
  556. }