Request.cpp 4.6 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146
  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. template<typename T>
  19. void Request::stream_into_impl(T& stream)
  20. {
  21. VERIFY(!m_internal_stream_data);
  22. m_internal_stream_data = make<InternalStreamData>(MUST(Core::Stream::File::adopt_fd(fd(), Core::Stream::OpenMode::Read)));
  23. m_internal_stream_data->read_notifier = Core::Notifier::construct(fd(), Core::Notifier::Read);
  24. auto user_on_finish = move(on_finish);
  25. on_finish = [this](auto success, auto total_size) {
  26. m_internal_stream_data->success = success;
  27. m_internal_stream_data->total_size = total_size;
  28. m_internal_stream_data->request_done = true;
  29. m_internal_stream_data->on_finish();
  30. };
  31. m_internal_stream_data->on_finish = [this, user_on_finish = move(user_on_finish)] {
  32. if (!m_internal_stream_data->user_finish_called && m_internal_stream_data->read_stream->is_eof()) {
  33. m_internal_stream_data->user_finish_called = true;
  34. user_on_finish(m_internal_stream_data->success, m_internal_stream_data->total_size);
  35. }
  36. };
  37. m_internal_stream_data->read_notifier->on_ready_to_read = [this, &stream] {
  38. constexpr size_t buffer_size = 256 * KiB;
  39. static char buf[buffer_size];
  40. do {
  41. auto result = m_internal_stream_data->read_stream->read({ buf, buffer_size });
  42. if (result.is_error() && (!result.error().is_errno() || (result.error().is_errno() && result.error().code() != EINTR)))
  43. break;
  44. if (result.is_error())
  45. continue;
  46. auto read_bytes = result.release_value();
  47. if (read_bytes.is_empty())
  48. break;
  49. if (!stream.write_or_error(read_bytes)) {
  50. // FIXME: What do we do here?
  51. TODO();
  52. }
  53. break;
  54. } while (true);
  55. if (m_internal_stream_data->read_stream->is_eof())
  56. m_internal_stream_data->read_notifier->close();
  57. if (m_internal_stream_data->request_done)
  58. m_internal_stream_data->on_finish();
  59. };
  60. }
  61. void Request::stream_into(Core::Stream::Stream& stream)
  62. {
  63. stream_into_impl(stream);
  64. }
  65. void Request::stream_into(OutputStream& stream)
  66. {
  67. stream_into_impl(stream);
  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, u32 total_size) {
  88. auto output_buffer = m_internal_buffered_data->payload_stream.copy_into_contiguous_buffer();
  89. on_buffered_request_finish(
  90. success,
  91. total_size,
  92. m_internal_buffered_data->response_headers,
  93. m_internal_buffered_data->response_code,
  94. output_buffer);
  95. };
  96. stream_into(m_internal_buffered_data->payload_stream);
  97. }
  98. void Request::did_finish(Badge<RequestClient>, bool success, u32 total_size)
  99. {
  100. if (!on_finish)
  101. return;
  102. on_finish(success, total_size);
  103. }
  104. void Request::did_progress(Badge<RequestClient>, Optional<u32> total_size, u32 downloaded_size)
  105. {
  106. if (on_progress)
  107. on_progress(total_size, downloaded_size);
  108. }
  109. void Request::did_receive_headers(Badge<RequestClient>, HashMap<String, String, CaseInsensitiveStringTraits> const& response_headers, Optional<u32> response_code)
  110. {
  111. if (on_headers_received)
  112. on_headers_received(response_headers, response_code);
  113. }
  114. void Request::did_request_certificates(Badge<RequestClient>)
  115. {
  116. if (on_certificate_requested) {
  117. auto result = on_certificate_requested();
  118. if (!m_client->set_certificate({}, *this, result.certificate, result.key)) {
  119. dbgln("Request: set_certificate failed");
  120. }
  121. }
  122. }
  123. }