#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) { } Error Client::Request(RequestPtr request, bool connect) { Restart(); if (connect) { // No existing socket connection was specified, create a new one. Connect(request); if (error_) { return error_; } } WriteReqeust(request); if (error_) { return error_; } ReadResponse(); return error_; } 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()); } } void Client::Restart() { io_context_.restart(); response_.reset(new Response{}); response_parser_.Init(response_.get()); closed_ = false; timer_canceled_ = false; error_ = Error{}; if (buffer_.size() != buffer_size_) { LOG_VERB("Resize buffer: %u -> %u.", buffer_.size(), buffer_size_); buffer_.resize(buffer_size_); } } void Client::Connect(RequestPtr request) { if (request->url().scheme() == "https") { #if WEBCC_ENABLE_SSL socket_.reset(new SslSocket{ io_context_, ssl_verify_ }); DoConnect(request, "443"); #else LOG_ERRO("SSL/HTTPS support is not enabled."); error_.Set(Error::kSyntaxError, "SSL/HTTPS is not supported"); #endif // WEBCC_ENABLE_SSL } else { socket_.reset(new Socket{ io_context_ }); DoConnect(request, "80"); } } void 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()); error_.Set(Error::kResolveError, "Host resolve error"); } 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(); // TODO: Handshake error error_.Set(Error::kConnectError, "Endpoint connect error"); } LOG_VERB("Socket connected."); } void 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(); error_.Set(Error::kSocketWriteError, "Socket write error"); } LOG_INFO("Request sent."); } void Client::ReadResponse() { LOG_VERB("Read response (timeout: %ds)...", timeout_); timer_.expires_after(std::chrono::seconds(timeout_)); DoWaitTimer(); DoReadResponse(); if (!error_) { LOG_VERB("HTTP response:\n%s", response_->Dump(4, "> ").c_str()); } } void Client::DoReadResponse() { boost::system::error_code ec = boost::asio::error::would_block; auto handler = [this, &ec](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_.Set(Error::kSocketReadError, "Socket read error"); 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_.Set(Error::kParseError, "HTTP parse error"); 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(); } }; 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."); error_.set_timeout(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