/** ByteBuffer HTTPResponse.cpp Copyright 2011-2025 Ramsey Kant Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at http://www.apache.org/licenses/LICENSE-2.0 Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License. */ #include "HTTPMessage.h" #include "HTTPResponse.h" #include #include #include #include HTTPResponse::HTTPResponse() : HTTPMessage() { } HTTPResponse::HTTPResponse(std::string const& sData) : HTTPMessage(sData) { } HTTPResponse::HTTPResponse(const uint8_t* pData, uint32_t len) : HTTPMessage(pData, len) { } /** * Determine the status code based on the parsed Responses reason string * The reason string is non standard so this method needs to change in order to handle * responses with different kinds of strings */ void HTTPResponse::determineStatusCode() { if (reason.contains("Continue")) { status = Status(CONTINUE); } else if (reason.contains("OK")) { status = Status(OK); } else if (reason.contains("Bad Request")) { status = Status(BAD_REQUEST); } else if (reason.contains("Method Not Allowed")) { status = Status(METHOD_NOT_ALLOWED); } else if (reason.contains("Not Found")) { status = Status(NOT_FOUND); } else if (reason.contains("Server Error")) { status = Status(SERVER_ERROR); } else if (reason.contains("Not Implemented")) { status = Status(NOT_IMPLEMENTED); } else { status = Status(NOT_IMPLEMENTED); } } /** * Determine the reason string based on the Response's status code */ void HTTPResponse::determineReasonStr() { switch (status) { case Status(CONTINUE): reason = "Continue"; break; case Status(OK): reason = "OK"; break; case Status(BAD_REQUEST): reason = "Bad Request"; break; case Status(METHOD_NOT_ALLOWED): reason = "Method Not Allowed"; break; case Status(NOT_FOUND): reason = "Not Found"; break; case Status(SERVER_ERROR): reason = "Internal Server Error"; break; case Status(NOT_IMPLEMENTED): reason = "Not Implemented"; break; default: break; } } /** * Create * Create and return a byte array of an HTTP response, built from the variables of this HTTPResponse * Caller will be responsible for cleaning up returned byte array * * @return Byte array of this HTTPResponse to be sent over the wire */ std::unique_ptr HTTPResponse::create() { // Clear the bytebuffer in the event this isn't the first call of create() clear(); // Insert the status line: \r\n putLine(std::format("{} {} {}", version, status, reason)); // Put all headers putHeaders(); // If theres body data, add it now if (this->data && this->dataLen > 0) { putBytes(this->data.get(), this->dataLen); } // Allocate space for the returned byte array and return it auto createRetData = std::make_unique(size()); setReadPos(0); getBytes(createRetData.get(), size()); return createRetData; } /** * Parse * Populate internal HTTPResponse variables by parsing the HTTP data * * @param True if successful. If false, sets parseErrorStr for reason of failure */ bool HTTPResponse::parse() { std::string statusstr; // Get elements from the status line: \r\n version = getStrElement(); statusstr = getStrElement(); reason = getLine(); // Pull till \r\n termination // Parse the status code integer directly; fall back to reason-string matching if malformed int32_t code = 0; auto [ptr, ec] = std::from_chars(statusstr.data(), statusstr.data() + statusstr.size(), code); if (ec == std::errc{}) { this->status = code; } else { determineStatusCode(); } // Optional - Validate the HTTP version. If there is a mismatch, discontinue parsing // if (strcmp(version.c_str(), HTTP_VERSION) != 0) { // parseErrorStr = "Supported HTTP version does not match"; // return false; // } // Parse and populate the headers map using the parseHeaders helper if (!parseHeaders()) return false; // If the body of the message if (!parseBody()) return false; return true; }