diff options
author | Daniel Baumann <daniel.baumann@progress-linux.org> | 2024-04-13 12:15:43 +0000 |
---|---|---|
committer | Daniel Baumann <daniel.baumann@progress-linux.org> | 2024-04-13 12:15:43 +0000 |
commit | f5f56e1a1c4d9e9496fcb9d81131066a964ccd23 (patch) | |
tree | 49e44c6f87febed37efb953ab5485aa49f6481a7 /src/lib/http/response_json.cc | |
parent | Initial commit. (diff) | |
download | isc-kea-f5f56e1a1c4d9e9496fcb9d81131066a964ccd23.tar.xz isc-kea-f5f56e1a1c4d9e9496fcb9d81131066a964ccd23.zip |
Adding upstream version 2.4.1.upstream/2.4.1upstream
Signed-off-by: Daniel Baumann <daniel.baumann@progress-linux.org>
Diffstat (limited to 'src/lib/http/response_json.cc')
-rw-r--r-- | src/lib/http/response_json.cc | 122 |
1 files changed, 122 insertions, 0 deletions
diff --git a/src/lib/http/response_json.cc b/src/lib/http/response_json.cc new file mode 100644 index 0000000..7543d76 --- /dev/null +++ b/src/lib/http/response_json.cc @@ -0,0 +1,122 @@ +// Copyright (C) 2016-2018 Internet Systems Consortium, Inc. ("ISC") +// +// This Source Code Form is subject to the terms of the Mozilla Public +// License, v. 2.0. If a copy of the MPL was not distributed with this +// file, You can obtain one at http://mozilla.org/MPL/2.0/. + +#include <config.h> + +#include <http/response_json.h> +#include <map> + +using namespace isc::data; + +namespace isc { +namespace http { + +HttpResponseJson::HttpResponseJson() + : HttpResponse() { + context()->headers_.push_back(HttpHeaderContext("Content-Type", "application/json")); +} + + +HttpResponseJson::HttpResponseJson(const HttpVersion& version, + const HttpStatusCode& status_code, + const CallSetGenericBody& generic_body) + : HttpResponse(version, status_code, CallSetGenericBody::no()) { + context()->headers_.push_back(HttpHeaderContext("Content-Type", "application/json")); + // This class provides its own implementation of the setGenericBody. + // We call it here unless the derived class calls this constructor + // from its own constructor and indicates that we shouldn't set the + // generic content in the body. + if (generic_body.set_) { + setGenericBody(status_code); + } +} + +void +HttpResponseJson::setGenericBody(const HttpStatusCode& status_code) { + // Only generate the content for the client or server errors. For + // other status codes (status OK in particular) the content should + // be created using setBodyAsJson or setBody. + if (isClientError(status_code) || isServerError(status_code)) { + std::map<std::string, ConstElementPtr> map_elements; + map_elements["result"] = + ConstElementPtr(new IntElement(statusCodeToNumber(status_code))); + map_elements["text"] = + ConstElementPtr(new StringElement(statusCodeToString(status_code))); + auto body = Element::createMap(); + body->setValue(map_elements); + setBodyAsJson(body); + } +} + +void +HttpResponseJson::finalize() { + if (!created_) { + create(); + } + + // Parse JSON body and store. + parseBodyAsJson(); + finalized_ = true; +} + +void +HttpResponseJson::reset() { + HttpResponse::reset(); + json_.reset(); +} + +ConstElementPtr +HttpResponseJson::getBodyAsJson() const { + checkFinalized(); + return (json_); +} + +void +HttpResponseJson::setBodyAsJson(const ConstElementPtr& json_body) { + if (json_body) { + context()->body_ = json_body->str(); + + } else { + context()->body_.clear(); + } + + json_ = json_body; +} + +ConstElementPtr +HttpResponseJson::getJsonElement(const std::string& element_name) const { + try { + ConstElementPtr body = getBodyAsJson(); + if (body) { + const std::map<std::string, ConstElementPtr>& map_value = body->mapValue(); + auto map_element = map_value.find(element_name); + if (map_element != map_value.end()) { + return (map_element->second); + } + } + + } catch (const std::exception& ex) { + isc_throw(HttpResponseJsonError, "unable to get JSON element " + << element_name << ": " << ex.what()); + } + return (ConstElementPtr()); +} + +void +HttpResponseJson::parseBodyAsJson() { + try { + // Only parse the body if it hasn't been parsed yet. + if (!json_ && !context_->body_.empty()) { + json_ = Element::fromJSON(context_->body_); + } + } catch (const std::exception& ex) { + isc_throw(HttpResponseJsonError, "unable to parse the body of the HTTP" + " response: " << ex.what()); + } +} + +} // namespace http +} // namespace isc |