diff options
Diffstat (limited to 'src/lib/yang/translator_option_def.cc')
| -rw-r--r-- | src/lib/yang/translator_option_def.cc | 208 |
1 files changed, 208 insertions, 0 deletions
diff --git a/src/lib/yang/translator_option_def.cc b/src/lib/yang/translator_option_def.cc new file mode 100644 index 0000000..a552191 --- /dev/null +++ b/src/lib/yang/translator_option_def.cc @@ -0,0 +1,208 @@ +// Copyright (C) 2018-2021 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 <yang/translator_option_def.h> +#include <yang/adaptor.h> +#include <yang/yang_models.h> +#include <sstream> + +using namespace std; +using namespace isc::data; +using namespace sysrepo; + +namespace isc { +namespace yang { + +TranslatorOptionDef::TranslatorOptionDef(S_Session session, + const string& model) + : TranslatorBasic(session, model) { +} + +TranslatorOptionDef::~TranslatorOptionDef() { +} + +ElementPtr +TranslatorOptionDef::getOptionDef(const string& xpath) { + try { + if ((model_ == KEA_DHCP4_SERVER) || + (model_ == KEA_DHCP6_SERVER)) { + return (getOptionDefKea(xpath)); + } + } catch (const sysrepo_exception& ex) { + isc_throw(SysrepoError, + "sysrepo error getting option definition at '" << xpath + << "': " << ex.what()); + } + isc_throw(NotImplemented, + "getOptionDef not implemented for the model: " << model_); +} + +ElementPtr +TranslatorOptionDef::getOptionDefKea(const string& xpath) { + ConstElementPtr code = getItem(xpath + "/code"); + ConstElementPtr name = getItem(xpath + "/name"); + ConstElementPtr type = getItem(xpath + "/type"); + ConstElementPtr space = getItem(xpath + "/space"); + if (!code || !space) { + // Can't happen as code and space are the keys. + isc_throw(Unexpected, "getOptionDefKea requires code and space: " + << xpath); + } + if (!name || !type) { + isc_throw(BadValue, "getOptionDefKea requires name and type: " + << xpath); + } + ElementPtr result = Element::createMap(); + result->set("code", code); + result->set("name", name); + result->set("type", type); + result->set("space", getItem(xpath + "/space")); + ConstElementPtr record = getItem(xpath + "/record-types"); + if (record) { + result->set("record-types", record); + } + ConstElementPtr array = getItem(xpath + "/array"); + if (array) { + result->set("array", array); + } + ConstElementPtr encapsulate = getItem(xpath + "/encapsulate"); + if (encapsulate) { + result->set("encapsulate", encapsulate); + } + ConstElementPtr context = getItem(xpath + "/user-context"); + if (context) { + result->set("user-context", Element::fromJSON(context->stringValue())); + } + return (result); +} + +void +TranslatorOptionDef::setOptionDef(const string& xpath, ConstElementPtr elem) { + try { + if ((model_ == KEA_DHCP4_SERVER) || + (model_ == KEA_DHCP6_SERVER)) { + setOptionDefKea(xpath, elem); + } else { + isc_throw(NotImplemented, + "setOptionDef not implemented for the model: " + << model_); + } + } catch (const sysrepo_exception& ex) { + isc_throw(SysrepoError, + "sysrepo error setting option definition '" << elem->str() + << "' at '" << xpath << "': " << ex.what()); + } +} + +void +TranslatorOptionDef::setOptionDefKea(const string& xpath, + ConstElementPtr elem) { + // Skip code and space as they are the keys. + ConstElementPtr name = elem->get("name"); + if (!name) { + isc_throw(BadValue, "option definition with name: " << elem->str()); + } + setItem(xpath + "/name", name, SR_STRING_T); + ConstElementPtr type = elem->get("type"); + if (!type) { + isc_throw(BadValue, "option definition with type: " << elem->str()); + } + setItem(xpath + "/type", type, SR_STRING_T); + ConstElementPtr record = elem->get("record-types"); + if (record) { + setItem(xpath + "/record-types", record, SR_STRING_T); + } + ConstElementPtr array = elem->get("array"); + if (array) { + setItem(xpath + "/array", array, SR_BOOL_T); + } + ConstElementPtr encapsulate = elem->get("encapsulate"); + if (encapsulate) { + setItem(xpath + "/encapsulate", encapsulate, SR_STRING_T); + } + ConstElementPtr context = Adaptor::getContext(elem); + if (context) { + setItem(xpath + "/user-context", Element::create(context->str()), + SR_STRING_T); + } +} + +TranslatorOptionDefList::TranslatorOptionDefList(S_Session session, + const string& model) + : TranslatorBasic(session, model), + TranslatorOptionDef(session, model) { +} + +TranslatorOptionDefList::~TranslatorOptionDefList() { +} + +ConstElementPtr +TranslatorOptionDefList::getOptionDefList(const string& xpath) { + try { + if ((model_ == KEA_DHCP4_SERVER) || + (model_ == KEA_DHCP6_SERVER)) { + return (getOptionDefListKea(xpath)); + } + } catch (const sysrepo_exception& ex) { + isc_throw(SysrepoError, + "sysrepo error getting option definition list at '" << xpath + << "': " << ex.what()); + } + isc_throw(NotImplemented, + "getOptionDefList not implemented for the model: " << model_); +} + +ConstElementPtr +TranslatorOptionDefList::getOptionDefListKea(const string& xpath) { + return getList<TranslatorOptionDef>(xpath + "/option-def", *this, + &TranslatorOptionDefList::getOptionDef); +} + +void +TranslatorOptionDefList::setOptionDefList(const string& xpath, + ConstElementPtr elem) { + try { + if ((model_ == KEA_DHCP4_SERVER) || + (model_ == KEA_DHCP6_SERVER)) { + setOptionDefListKea(xpath, elem); + } else { + isc_throw(NotImplemented, + "setOptionDefList not implemented for the model: " + << model_); + } + } catch (const sysrepo_exception& ex) { + isc_throw(SysrepoError, + "sysrepo error setting option definition list '" + << elem->str() << "' at '" << xpath << "': " << ex.what()); + } +} + +void +TranslatorOptionDefList::setOptionDefListKea(const string& xpath, + ConstElementPtr elem) { + for (size_t i = 0; i < elem->size(); ++i) { + ConstElementPtr def = elem->get(i); + if (!def->contains("code")) { + isc_throw(BadValue, + "option definition without code: " << def->str()); + } + unsigned code = static_cast<unsigned>(def->get("code")->intValue()); + if (!def->contains("space")) { + isc_throw(BadValue, + "option definition without space: " << def->str()); + } + string space = def->get("space")->stringValue(); + ostringstream keys; + keys << xpath << "/option-def[code='" << code + << "'][space='" << space << "']"; + setOptionDef(keys.str(), def); + } +} + +} // namespace yang +} // namespace isc |