#pragma once #include "logging.hpp" #include "nlohmann/json.hpp" #include #include #include #include #include #include namespace crow { template class Connection; struct Response { template friend class crow::Connection; using response_type = boost::beast::http::response; std::optional stringResponse; nlohmann::json jsonValue; void addHeader(const std::string_view key, const std::string_view value) { stringResponse->set(key, value); } void addHeader(boost::beast::http::field key, std::string_view value) { stringResponse->set(key, value); } Response() : stringResponse(response_type{}) {} ~Response() = default; Response(const Response&) = delete; Response(Response&&) = delete; Response& operator=(const Response& r) = delete; Response& operator=(Response&& r) noexcept { BMCWEB_LOG_DEBUG << "Moving response containers; this: " << this << "; other: " << &r; if (this == &r) { return *this; } stringResponse = std::move(r.stringResponse); r.stringResponse.emplace(response_type{}); jsonValue = std::move(r.jsonValue); completed = r.completed; completeRequestHandler = std::move(r.completeRequestHandler); isAliveHelper = std::move(r.isAliveHelper); r.completeRequestHandler = nullptr; r.isAliveHelper = nullptr; return *this; } void result(boost::beast::http::status v) { stringResponse->result(v); } boost::beast::http::status result() { return stringResponse->result(); } unsigned resultInt() { return stringResponse->result_int(); } std::string_view reason() { return stringResponse->reason(); } bool isCompleted() const noexcept { return completed; } std::string& body() { return stringResponse->body(); } void keepAlive(bool k) { stringResponse->keep_alive(k); } bool keepAlive() { return stringResponse->keep_alive(); } void preparePayload() { stringResponse->prepare_payload(); } void clear() { BMCWEB_LOG_DEBUG << this << " Clearing response containers"; stringResponse.emplace(response_type{}); jsonValue.clear(); completed = false; } void write(std::string_view bodyPart) { stringResponse->body() += std::string(bodyPart); } void end() { // Only set etag if this request succeeded if (result() == boost::beast::http::status::ok) { // and the json response isn't empty if (!jsonValue.empty()) { size_t hashval = std::hash{}(jsonValue); std::string hexVal = "\"" + intToHexString(hashval, 8) + "\""; addHeader(boost::beast::http::field::etag, hexVal); } } if (completed) { BMCWEB_LOG_ERROR << this << " Response was ended twice"; return; } completed = true; BMCWEB_LOG_DEBUG << this << " calling completion handler"; if (completeRequestHandler) { BMCWEB_LOG_DEBUG << this << " completion handler was valid"; completeRequestHandler(*this); } } bool isAlive() { return isAliveHelper && isAliveHelper(); } void setCompleteRequestHandler(std::function&& handler) { BMCWEB_LOG_DEBUG << this << " setting completion handler"; completeRequestHandler = std::move(handler); } std::function releaseCompleteRequestHandler() { BMCWEB_LOG_DEBUG << this << " releasing completion handler" << static_cast(completeRequestHandler); std::function ret = completeRequestHandler; completeRequestHandler = nullptr; return ret; } void setIsAliveHelper(std::function&& handler) { isAliveHelper = std::move(handler); } std::function releaseIsAliveHelper() { std::function ret = std::move(isAliveHelper); isAliveHelper = nullptr; return ret; } private: bool completed = false; std::function completeRequestHandler; std::function isAliveHelper; // In case of a JSON object, set the Content-Type header void jsonMode() { addHeader("Content-Type", "application/json"); } }; } // namespace crow