Request.cpp 5.1 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147
  1. /*
  2. * Copyright (c) 2018-2020, Andreas Kling <kling@serenityos.org>
  3. *
  4. * SPDX-License-Identifier: BSD-2-Clause
  5. */
  6. #include <LibProtocol/Request.h>
  7. #include <LibProtocol/RequestClient.h>
  8. namespace Protocol {
  9. Request::Request(RequestClient& client, i32 request_id)
  10. : m_client(client)
  11. , m_request_id(request_id)
  12. {
  13. }
  14. bool Request::stop()
  15. {
  16. return m_client->stop_request({}, *this);
  17. }
  18. void Request::set_request_fd(Badge<Protocol::RequestClient>, int fd)
  19. {
  20. VERIFY(m_fd == -1);
  21. m_fd = fd;
  22. auto notifier = Core::Notifier::construct(fd, Core::Notifier::Type::Read);
  23. auto stream = MUST(Core::File::adopt_fd(fd, Core::File::OpenMode::Read));
  24. notifier->on_activation = move(m_internal_stream_data->read_notifier->on_activation);
  25. m_internal_stream_data->read_notifier = move(notifier);
  26. m_internal_stream_data->read_stream = move(stream);
  27. }
  28. void Request::stream_into(Stream& stream)
  29. {
  30. VERIFY(!m_internal_stream_data);
  31. m_internal_stream_data = make<InternalStreamData>();
  32. m_internal_stream_data->read_notifier = Core::Notifier::construct(fd(), Core::Notifier::Type::Read);
  33. if (fd() != -1)
  34. m_internal_stream_data->read_stream = MUST(Core::File::adopt_fd(fd(), Core::File::OpenMode::Read));
  35. auto user_on_finish = move(on_finish);
  36. on_finish = [this](auto success, auto total_size) {
  37. m_internal_stream_data->success = success;
  38. m_internal_stream_data->total_size = total_size;
  39. m_internal_stream_data->request_done = true;
  40. m_internal_stream_data->on_finish();
  41. };
  42. m_internal_stream_data->on_finish = [this, user_on_finish = move(user_on_finish)] {
  43. if (!m_internal_stream_data->user_finish_called && m_internal_stream_data->read_stream->is_eof()) {
  44. m_internal_stream_data->user_finish_called = true;
  45. user_on_finish(m_internal_stream_data->success, m_internal_stream_data->total_size);
  46. }
  47. };
  48. m_internal_stream_data->read_notifier->on_activation = [this, &stream] {
  49. constexpr size_t buffer_size = 256 * KiB;
  50. static char buf[buffer_size];
  51. do {
  52. auto result = m_internal_stream_data->read_stream->read_some({ buf, buffer_size });
  53. if (result.is_error() && (!result.error().is_errno() || (result.error().is_errno() && result.error().code() != EINTR)))
  54. break;
  55. if (result.is_error())
  56. continue;
  57. auto read_bytes = result.release_value();
  58. if (read_bytes.is_empty())
  59. break;
  60. // FIXME: What do we do if this fails?
  61. stream.write_until_depleted(read_bytes).release_value_but_fixme_should_propagate_errors();
  62. } while (true);
  63. if (m_internal_stream_data->read_stream->is_eof())
  64. m_internal_stream_data->read_notifier->close();
  65. if (m_internal_stream_data->request_done)
  66. m_internal_stream_data->on_finish();
  67. };
  68. }
  69. void Request::set_should_buffer_all_input(bool value)
  70. {
  71. if (m_should_buffer_all_input == value)
  72. return;
  73. if (m_internal_buffered_data && !value) {
  74. m_internal_buffered_data = nullptr;
  75. m_should_buffer_all_input = false;
  76. return;
  77. }
  78. VERIFY(!m_internal_stream_data);
  79. VERIFY(!m_internal_buffered_data);
  80. VERIFY(on_buffered_request_finish); // Not having this set makes no sense.
  81. m_internal_buffered_data = make<InternalBufferedData>();
  82. m_should_buffer_all_input = true;
  83. on_headers_received = [this](auto& headers, auto response_code) {
  84. m_internal_buffered_data->response_headers = headers;
  85. m_internal_buffered_data->response_code = move(response_code);
  86. };
  87. on_finish = [this](auto success, auto total_size) {
  88. auto output_buffer = ByteBuffer::create_uninitialized(m_internal_buffered_data->payload_stream.used_buffer_size()).release_value_but_fixme_should_propagate_errors();
  89. m_internal_buffered_data->payload_stream.read_until_filled(output_buffer).release_value_but_fixme_should_propagate_errors();
  90. on_buffered_request_finish(
  91. success,
  92. total_size,
  93. m_internal_buffered_data->response_headers,
  94. m_internal_buffered_data->response_code,
  95. output_buffer);
  96. };
  97. stream_into(m_internal_buffered_data->payload_stream);
  98. }
  99. void Request::did_finish(Badge<RequestClient>, bool success, u64 total_size)
  100. {
  101. if (!on_finish)
  102. return;
  103. on_finish(success, total_size);
  104. }
  105. void Request::did_progress(Badge<RequestClient>, Optional<u64> total_size, u64 downloaded_size)
  106. {
  107. if (on_progress)
  108. on_progress(total_size, downloaded_size);
  109. }
  110. void Request::did_receive_headers(Badge<RequestClient>, HashMap<ByteString, ByteString, CaseInsensitiveStringTraits> const& response_headers, Optional<u32> response_code)
  111. {
  112. if (on_headers_received)
  113. on_headers_received(response_headers, response_code);
  114. }
  115. void Request::did_request_certificates(Badge<RequestClient>)
  116. {
  117. if (on_certificate_requested) {
  118. auto result = on_certificate_requested();
  119. if (!m_client->set_certificate({}, *this, result.certificate, result.key)) {
  120. dbgln("Request: set_certificate failed");
  121. }
  122. }
  123. }
  124. }