#include "webcc/client.h" #include "webcc/logger.h" using boost::asio::ip::tcp; namespace webcc { Client::Client() : timer_(io_context_), ssl_verify_(true), buffer_size_(kBufferSize), timeout_(kMaxReadSeconds), closed_(false), timer_canceled_(false), timed_out_(false), error_(kNoError) { } bool Client::Request(RequestPtr request, bool connect) { io_context_.restart(); response_.reset(new Response{}); response_parser_.Init(response_.get()); closed_ = false; timer_canceled_ = false; timed_out_ = false; error_ = kNoError; if (buffer_.size() != buffer_size_) { LOG_VERB("Resize buffer: %u -> %u.", buffer_.size(), buffer_size_); buffer_.resize(buffer_size_); } if (connect) { // No existing socket connection was specified, create a new one. if ((error_ = Connect(request)) != kNoError) { return false; } } if ((error_ = WriteReqeust(request)) != kNoError) { return false; } if ((error_ = ReadResponse()) != kNoError) { return false; } return true; } void Client::Close() { if (closed_) { return; } closed_ = true; LOG_INFO("Close socket..."); boost::system::error_code ec; socket_->Close(&ec); if (ec) { LOG_ERRO("Socket close error (%s).", ec.message().c_str()); } } Error Client::Connect(RequestPtr request) { if (request->url().scheme() == "https") { #if WEBCC_ENABLE_SSL socket_.reset(new SslSocket{ io_context_, ssl_verify_ }); return DoConnect(request, "443"); #else LOG_ERRO("SSL/HTTPS support is not enabled."); return kSchemaError; #endif // WEBCC_ENABLE_SSL } else { socket_.reset(new Socket{ io_context_ }); return DoConnect(request, "80"); } } Error Client::DoConnect(RequestPtr request, const std::string& default_port) { tcp::resolver resolver(io_context_); std::string port = request->port(default_port); boost::system::error_code ec; auto endpoints = resolver.resolve(tcp::v4(), request->host(), port, ec); if (ec) { LOG_ERRO("Host resolve error (%s): %s, %s.", ec.message().c_str(), request->host().c_str(), port.c_str()); return kHostResolveError; } LOG_VERB("Connect to server..."); // Use sync API directly since we don't need timeout control. socket_->Connect(request->host(), endpoints, &ec); // Determine whether a connection was successfully established. if (ec) { LOG_ERRO("Socket connect error (%s).", ec.message().c_str()); Close(); return kEndpointConnectError; } LOG_VERB("Socket connected."); return kNoError; } Error Client::WriteReqeust(RequestPtr request) { LOG_VERB("HTTP request:\n%s", request->Dump(4, "> ").c_str()); // NOTE: // It doesn't make much sense to set a timeout for socket write. // I find that it's almost impossible to simulate a situation in the server // side to test this timeout. boost::system::error_code ec; // Use sync API directly since we don't need timeout control. socket_->Write(*request, &ec); if (ec) { LOG_ERRO("Socket write error (%s).", ec.message().c_str()); Close(); return kSocketWriteError; } LOG_INFO("Request sent."); return kNoError; } Error Client::ReadResponse() { LOG_VERB("Read response (timeout: %ds)...", timeout_); timer_.expires_after(std::chrono::seconds(timeout_)); DoWaitTimer(); Error error = kNoError; DoReadResponse(&error); if (error == kNoError) { LOG_VERB("HTTP response:\n%s", response_->Dump(4, "> ").c_str()); } return error; } void Client::DoReadResponse(Error* error) { boost::system::error_code ec = boost::asio::error::would_block; auto handler = [this, &ec, error](boost::system::error_code inner_ec, std::size_t length) { ec = inner_ec; LOG_VERB("Socket async read handler."); // Stop the deadline timer once the read has started (or failed). CancelTimer(); // TODO: Is it necessary to check `length == 0`? if (ec || length == 0) { Close(); *error = kSocketReadError; LOG_ERRO("Socket read error (%s).", ec.message().c_str()); return; } LOG_INFO("Read data, length: %u.", length); // Parse the response piece just read. if (!response_parser_.Parse(buffer_.data(), length)) { Close(); *error = kHttpError; LOG_ERRO("Failed to parse HTTP response."); return; } if (response_parser_.finished()) { // Stop trying to read once all content has been received, because // some servers will block extra call to read_some(). if (response_->IsConnectionKeepAlive()) { // Close the timer but keep the socket connection. LOG_INFO("Keep the socket connection alive."); } else { Close(); } LOG_INFO("Finished to read and parse HTTP response."); // Stop reading. return; } if (!closed_) { DoReadResponse(error); } }; socket_->AsyncReadSome(std::move(handler), &buffer_); // Block until the asynchronous operation has completed. do { io_context_.run_one(); } while (ec == boost::asio::error::would_block); } void Client::DoWaitTimer() { LOG_VERB("Wait timer asynchronously."); timer_.async_wait(std::bind(&Client::OnTimer, this, std::placeholders::_1)); } void Client::OnTimer(boost::system::error_code ec) { LOG_VERB("On timer."); // timer_.cancel() was called. if (ec == boost::asio::error::operation_aborted) { LOG_VERB("Timer canceled."); return; } if (closed_) { LOG_VERB("Socket has been closed."); return; } if (timer_.expiry() <= boost::asio::steady_timer::clock_type::now()) { // The deadline has passed. The socket is closed so that any outstanding // asynchronous operations are canceled. LOG_WARN("HTTP client timed out."); timed_out_ = true; Close(); return; } // Put the actor back to sleep. DoWaitTimer(); } void Client::CancelTimer() { if (timer_canceled_) { return; } LOG_INFO("Cancel timer..."); timer_.cancel(); timer_canceled_ = true; } } // namespace webcc