blob: 499597f41d917d5c1b5e36b90ee0617abf95f61d [file] [log] [blame]
Václav Kubernát80aacc02018-08-22 17:41:54 +02001/*
2 * Copyright (C) 2018 CESNET, https://photonics.cesnet.cz/
3 * Copyright (C) 2018 FIT CVUT, https://fit.cvut.cz/
4 *
5 * Written by Václav Kubernát <kubervac@fit.cvut.cz>
6 *
7*/
8
Jan Kundrát68d4a2c2018-10-01 17:17:09 +02009#include <sysrepo-cpp/Session.hpp>
Václav Kubernát80aacc02018-08-22 17:41:54 +020010#include "sysrepo_access.hpp"
Václav Kubernáta6c5fff2018-09-07 15:16:25 +020011#include "yang_schema.hpp"
Václav Kubernát80aacc02018-08-22 17:41:54 +020012
Jan Kundrát68d4a2c2018-10-01 17:17:09 +020013leaf_data_ leafValueFromVal(const sysrepo::S_Val& value)
Václav Kubernátc89736b2018-08-30 16:14:05 +020014{
Václav Kubernátb6ff0b62018-08-30 16:14:53 +020015 using namespace std::string_literals;
Václav Kubernátc89736b2018-08-30 16:14:05 +020016 switch (value->type()) {
Ivona Oboňová88c78ca2019-07-02 18:40:07 +020017 case SR_INT8_T:
18 return value->data()->get_int8();
19 case SR_UINT8_T:
20 return value->data()->get_uint8();
21 case SR_INT16_T:
22 return value->data()->get_int16();
23 case SR_UINT16_T:
24 return value->data()->get_uint16();
Václav Kubernátb6ff0b62018-08-30 16:14:53 +020025 case SR_INT32_T:
26 return value->data()->get_int32();
27 case SR_UINT32_T:
28 return value->data()->get_uint32();
Ivona Oboňová88c78ca2019-07-02 18:40:07 +020029 case SR_INT64_T:
30 return value->data()->get_int64();
31 case SR_UINT64_T:
32 return value->data()->get_uint64();
Václav Kubernátb6ff0b62018-08-30 16:14:53 +020033 case SR_BOOL_T:
34 return value->data()->get_bool();
35 case SR_STRING_T:
36 return std::string(value->data()->get_string());
37 case SR_ENUM_T:
Václav Kubernát152ce222019-12-19 12:23:32 +010038 return enum_{std::string(value->data()->get_enum())};
Václav Kubernátb6ff0b62018-08-30 16:14:53 +020039 case SR_DECIMAL64_T:
40 return value->data()->get_decimal64();
41 case SR_CONTAINER_T:
Václav Kubernát144729d2020-01-08 15:20:35 +010042 return special_{SpecialValue::Container};
Václav Kubernátb6ff0b62018-08-30 16:14:53 +020043 case SR_CONTAINER_PRESENCE_T:
Václav Kubernát144729d2020-01-08 15:20:35 +010044 return special_{SpecialValue::PresenceContainer};
Václav Kubernátb6ff0b62018-08-30 16:14:53 +020045 case SR_LIST_T:
Václav Kubernát144729d2020-01-08 15:20:35 +010046 return special_{SpecialValue::List};
Václav Kubernátb6ff0b62018-08-30 16:14:53 +020047 default: // TODO: implement all types
48 return value->val_to_string();
Václav Kubernátc89736b2018-08-30 16:14:05 +020049 }
50}
Václav Kubernát80aacc02018-08-22 17:41:54 +020051
Jan Kundrát68d4a2c2018-10-01 17:17:09 +020052struct valFromValue : boost::static_visitor<sysrepo::S_Val> {
53 sysrepo::S_Val operator()(const enum_& value) const
Václav Kubernát80aacc02018-08-22 17:41:54 +020054 {
Jan Kundrát68d4a2c2018-10-01 17:17:09 +020055 return std::make_shared<sysrepo::Val>(value.m_value.c_str(), SR_ENUM_T);
Václav Kubernát80aacc02018-08-22 17:41:54 +020056 }
57
Václav Kubernátab538992019-03-06 15:30:50 +010058 sysrepo::S_Val operator()(const binary_& value) const
59 {
60 return std::make_shared<sysrepo::Val>(value.m_value.c_str(), SR_BINARY_T);
61 }
62
Václav Kubernáteeb38842019-03-20 19:46:05 +010063 sysrepo::S_Val operator()(const identityRef_& value) const
64 {
65 auto res = value.m_prefix.value().m_name + ":" + value.m_value;
66 return std::make_shared<sysrepo::Val>(res.c_str(), SR_IDENTITYREF_T);
67 }
68
Václav Kubernát144729d2020-01-08 15:20:35 +010069 sysrepo::S_Val operator()(const special_& value) const
70 {
71 throw std::runtime_error("Tried constructing S_Val from a " + specialValueToString(value));
72 }
73
Jan Kundrát68d4a2c2018-10-01 17:17:09 +020074 sysrepo::S_Val operator()(const std::string& value) const
Václav Kubernát80aacc02018-08-22 17:41:54 +020075 {
Jan Kundrát68d4a2c2018-10-01 17:17:09 +020076 return std::make_shared<sysrepo::Val>(value.c_str());
Václav Kubernát80aacc02018-08-22 17:41:54 +020077 }
78
Jan Kundrátbd178362019-02-05 19:00:04 +010079 template <typename T>
80 sysrepo::S_Val operator()(const T& value) const
Václav Kubernát80aacc02018-08-22 17:41:54 +020081 {
Jan Kundrát68d4a2c2018-10-01 17:17:09 +020082 return std::make_shared<sysrepo::Val>(value);
Václav Kubernát80aacc02018-08-22 17:41:54 +020083 }
84};
85
Václav Kubernát812ee282018-08-30 17:10:03 +020086SysrepoAccess::~SysrepoAccess() = default;
Václav Kubernát80aacc02018-08-22 17:41:54 +020087
88SysrepoAccess::SysrepoAccess(const std::string& appname)
Jan Kundrát68d4a2c2018-10-01 17:17:09 +020089 : m_connection(new sysrepo::Connection(appname.c_str()))
Václav Kubernáta6c5fff2018-09-07 15:16:25 +020090 , m_schema(new YangSchema())
Václav Kubernát80aacc02018-08-22 17:41:54 +020091{
Václav Kubernátc58e4aa2019-04-03 18:37:32 +020092 try {
93 m_session = std::make_shared<sysrepo::Session>(m_connection);
94 } catch (sysrepo::sysrepo_exception& ex) {
95 reportErrors();
96 }
Václav Kubernátb52dc252019-12-04 13:03:39 +010097
98 // If fetching a submodule, sysrepo::Session::get_schema will determine the revision from the main module.
99 // That's why submoduleRevision is ignored.
100 m_schema->registerModuleCallback([this](const char* moduleName, const char* revision, const char* submodule, [[maybe_unused]] const char* submoduleRevision) {
Václav Kubernáta6c5fff2018-09-07 15:16:25 +0200101 return fetchSchema(moduleName, revision, submodule);
102 });
103
Václav Kubernátbf9c6112019-11-04 16:03:35 +0100104 for (const auto& it : listSchemas()) {
105 if (it->implemented()) {
106 m_schema->loadModule(it->module_name());
107 for (unsigned int i = 0; i < it->enabled_feature_cnt(); i++) {
108 m_schema->enableFeature(it->module_name(), it->enabled_features(i));
109 }
110 }
Václav Kubernáta6c5fff2018-09-07 15:16:25 +0200111 }
Václav Kubernát80aacc02018-08-22 17:41:54 +0200112}
113
Jan Kundrátb331b552020-01-23 15:25:29 +0100114DatastoreAccess::Tree SysrepoAccess::getItems(const std::string& path)
Václav Kubernát80aacc02018-08-22 17:41:54 +0200115{
Václav Kubernátb6ff0b62018-08-30 16:14:53 +0200116 using namespace std::string_literals;
Jan Kundrátb331b552020-01-23 15:25:29 +0100117 Tree res;
Václav Kubernát80aacc02018-08-22 17:41:54 +0200118
Václav Kubernátb6ff0b62018-08-30 16:14:53 +0200119 auto fillMap = [&res](auto items) {
120 if (!items)
121 return;
122 for (unsigned int i = 0; i < items->val_cnt(); i++) {
123 res.emplace(items->val(i)->xpath(), leafValueFromVal(items->val(i)));
124 }
125 };
Václav Kubernátc89736b2018-08-30 16:14:05 +0200126
Václav Kubernátc58e4aa2019-04-03 18:37:32 +0200127 try {
128 if (path == "/") {
129 // Sysrepo doesn't have a root node ("/"), so we take all top-level nodes from all schemas
130 auto schemas = m_session->list_schemas();
131 for (unsigned int i = 0; i < schemas->schema_cnt(); i++) {
132 fillMap(m_session->get_items(("/"s + schemas->schema(i)->module_name() + ":*//.").c_str()));
133 }
134 } else {
135 fillMap(m_session->get_items((path + "//.").c_str()));
Václav Kubernátb6ff0b62018-08-30 16:14:53 +0200136 }
Václav Kubernátc58e4aa2019-04-03 18:37:32 +0200137 } catch (sysrepo::sysrepo_exception& ex) {
138 reportErrors();
Václav Kubernátc89736b2018-08-30 16:14:05 +0200139 }
Václav Kubernát80aacc02018-08-22 17:41:54 +0200140 return res;
141}
142
143void SysrepoAccess::setLeaf(const std::string& path, leaf_data_ value)
144{
Václav Kubernátc58e4aa2019-04-03 18:37:32 +0200145 try {
146 m_session->set_item(path.c_str(), boost::apply_visitor(valFromValue(), value));
147 } catch (sysrepo::sysrepo_exception& ex) {
148 reportErrors();
149 }
Václav Kubernát80aacc02018-08-22 17:41:54 +0200150}
151
152void SysrepoAccess::createPresenceContainer(const std::string& path)
153{
Václav Kubernátc58e4aa2019-04-03 18:37:32 +0200154 try {
155 m_session->set_item(path.c_str());
156 } catch (sysrepo::sysrepo_exception& ex) {
157 reportErrors();
158 }
Václav Kubernát80aacc02018-08-22 17:41:54 +0200159}
160
161void SysrepoAccess::deletePresenceContainer(const std::string& path)
162{
Václav Kubernátc58e4aa2019-04-03 18:37:32 +0200163 try {
164 m_session->delete_item(path.c_str());
165 } catch (sysrepo::sysrepo_exception& ex) {
166 reportErrors();
167 }
Václav Kubernát80aacc02018-08-22 17:41:54 +0200168}
Václav Kubernát812ee282018-08-30 17:10:03 +0200169
Václav Kubernátf5f64f02019-03-19 17:15:47 +0100170void SysrepoAccess::createListInstance(const std::string& path)
171{
Václav Kubernátc58e4aa2019-04-03 18:37:32 +0200172 try {
173 m_session->set_item(path.c_str());
174 } catch (sysrepo::sysrepo_exception& ex) {
175 reportErrors();
176 }
Václav Kubernátf5f64f02019-03-19 17:15:47 +0100177}
178
179void SysrepoAccess::deleteListInstance(const std::string& path)
180{
Václav Kubernátc58e4aa2019-04-03 18:37:32 +0200181 try {
182 m_session->delete_item(path.c_str());
183 } catch (sysrepo::sysrepo_exception& ex) {
184 reportErrors();
185 }
Václav Kubernátf5f64f02019-03-19 17:15:47 +0100186}
187
Václav Kubernát812ee282018-08-30 17:10:03 +0200188void SysrepoAccess::commitChanges()
189{
Václav Kubernátc58e4aa2019-04-03 18:37:32 +0200190 try {
191 m_session->commit();
192 } catch (sysrepo::sysrepo_exception& ex) {
193 reportErrors();
194 }
Václav Kubernát812ee282018-08-30 17:10:03 +0200195}
Václav Kubernáta6c5fff2018-09-07 15:16:25 +0200196
Václav Kubernát6d791432018-10-25 16:00:35 +0200197void SysrepoAccess::discardChanges()
198{
Václav Kubernátc58e4aa2019-04-03 18:37:32 +0200199 try {
200 m_session->discard_changes();
201 } catch (sysrepo::sysrepo_exception& ex) {
202 reportErrors();
203 }
Václav Kubernát6d791432018-10-25 16:00:35 +0200204}
205
Václav Kubernáta6c5fff2018-09-07 15:16:25 +0200206std::string SysrepoAccess::fetchSchema(const char* module, const char* revision, const char* submodule)
207{
Václav Kubernátc58e4aa2019-04-03 18:37:32 +0200208 std::string schema;
209 try {
Václav Kubernátb52dc252019-12-04 13:03:39 +0100210 schema = m_session->get_schema(module, revision, submodule, SR_SCHEMA_YANG);
Václav Kubernátc58e4aa2019-04-03 18:37:32 +0200211 } catch (sysrepo::sysrepo_exception& ex) {
212 reportErrors();
213 }
214
Václav Kubernáta6c5fff2018-09-07 15:16:25 +0200215 if (schema.empty())
216 throw std::runtime_error(std::string("Module ") + module + " not available");
217
218 return schema;
219}
220
Václav Kubernátbf9c6112019-11-04 16:03:35 +0100221std::vector<std::shared_ptr<sysrepo::Yang_Schema>> SysrepoAccess::listSchemas()
Václav Kubernáta6c5fff2018-09-07 15:16:25 +0200222{
Václav Kubernátbf9c6112019-11-04 16:03:35 +0100223 std::vector<sysrepo::S_Yang_Schema> res;
Václav Kubernátc58e4aa2019-04-03 18:37:32 +0200224 std::shared_ptr<sysrepo::Yang_Schemas> schemas;
225 try {
226 schemas = m_session->list_schemas();
227 } catch (sysrepo::sysrepo_exception& ex) {
228 reportErrors();
229 }
Václav Kubernáta6c5fff2018-09-07 15:16:25 +0200230 for (unsigned int i = 0; i < schemas->schema_cnt(); i++) {
231 auto schema = schemas->schema(i);
Václav Kubernátbf9c6112019-11-04 16:03:35 +0100232 res.push_back(schema);
Václav Kubernáta6c5fff2018-09-07 15:16:25 +0200233 }
234 return res;
235}
236
237std::shared_ptr<Schema> SysrepoAccess::schema()
238{
239 return m_schema;
240}
Václav Kubernátc58e4aa2019-04-03 18:37:32 +0200241
242[[noreturn]] void SysrepoAccess::reportErrors()
243{
244 // I only use get_last_errors to get error info, since the error code from
245 // sysrepo_exception doesn't really give any meaningful information. For
246 // example an "invalid argument" error could mean a node isn't enabled, or
247 // it could mean something totally different and there is no documentation
248 // for that, so it's better to just use the message sysrepo gives me.
249 auto srErrors = m_session->get_last_errors();
250 std::vector<DatastoreError> res;
251
252 for (size_t i = 0; i < srErrors->error_cnt(); i++) {
253 auto error = srErrors->error(i);
254 res.emplace_back(error->message(), error->xpath() ? std::optional<std::string>{error->xpath()} : std::nullopt);
255 }
256
257 throw DatastoreException(res);
258}