blob: 4e1ab4bb851a5ff297182225633110a4370fbd4b [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()) {
Václav Kubernátb6ff0b62018-08-30 16:14:53 +020017 case SR_INT32_T:
18 return value->data()->get_int32();
19 case SR_UINT32_T:
20 return value->data()->get_uint32();
21 case SR_BOOL_T:
22 return value->data()->get_bool();
23 case SR_STRING_T:
24 return std::string(value->data()->get_string());
25 case SR_ENUM_T:
26 return std::string(value->data()->get_enum());
27 case SR_DECIMAL64_T:
28 return value->data()->get_decimal64();
29 case SR_CONTAINER_T:
30 return "(container)"s;
31 case SR_CONTAINER_PRESENCE_T:
32 return "(presence container)"s;
33 case SR_LIST_T:
34 return "(list)"s;
35 default: // TODO: implement all types
36 return value->val_to_string();
Václav Kubernátc89736b2018-08-30 16:14:05 +020037 }
38}
Václav Kubernát80aacc02018-08-22 17:41:54 +020039
Jan Kundrát68d4a2c2018-10-01 17:17:09 +020040struct valFromValue : boost::static_visitor<sysrepo::S_Val> {
41 sysrepo::S_Val operator()(const enum_& value) const
Václav Kubernát80aacc02018-08-22 17:41:54 +020042 {
Jan Kundrát68d4a2c2018-10-01 17:17:09 +020043 return std::make_shared<sysrepo::Val>(value.m_value.c_str(), SR_ENUM_T);
Václav Kubernát80aacc02018-08-22 17:41:54 +020044 }
45
Václav Kubernátab538992019-03-06 15:30:50 +010046 sysrepo::S_Val operator()(const binary_& value) const
47 {
48 return std::make_shared<sysrepo::Val>(value.m_value.c_str(), SR_BINARY_T);
49 }
50
Václav Kubernáteeb38842019-03-20 19:46:05 +010051 sysrepo::S_Val operator()(const identityRef_& value) const
52 {
53 auto res = value.m_prefix.value().m_name + ":" + value.m_value;
54 return std::make_shared<sysrepo::Val>(res.c_str(), SR_IDENTITYREF_T);
55 }
56
Jan Kundrát68d4a2c2018-10-01 17:17:09 +020057 sysrepo::S_Val operator()(const std::string& value) const
Václav Kubernát80aacc02018-08-22 17:41:54 +020058 {
Jan Kundrát68d4a2c2018-10-01 17:17:09 +020059 return std::make_shared<sysrepo::Val>(value.c_str());
Václav Kubernát80aacc02018-08-22 17:41:54 +020060 }
61
Jan Kundrátbd178362019-02-05 19:00:04 +010062 template <typename T>
63 sysrepo::S_Val operator()(const T& value) const
Václav Kubernát80aacc02018-08-22 17:41:54 +020064 {
Jan Kundrát68d4a2c2018-10-01 17:17:09 +020065 return std::make_shared<sysrepo::Val>(value);
Václav Kubernát80aacc02018-08-22 17:41:54 +020066 }
67};
68
Václav Kubernát812ee282018-08-30 17:10:03 +020069SysrepoAccess::~SysrepoAccess() = default;
Václav Kubernát80aacc02018-08-22 17:41:54 +020070
71SysrepoAccess::SysrepoAccess(const std::string& appname)
Jan Kundrát68d4a2c2018-10-01 17:17:09 +020072 : m_connection(new sysrepo::Connection(appname.c_str()))
Václav Kubernáta6c5fff2018-09-07 15:16:25 +020073 , m_schema(new YangSchema())
Václav Kubernát80aacc02018-08-22 17:41:54 +020074{
Jan Kundrát68d4a2c2018-10-01 17:17:09 +020075 m_session = std::make_shared<sysrepo::Session>(m_connection);
Václav Kubernáta6c5fff2018-09-07 15:16:25 +020076 m_schema->registerModuleCallback([this](const char* moduleName, const char* revision, const char* submodule) {
77 return fetchSchema(moduleName, revision, submodule);
78 });
79
80 for (const auto& it : listImplementedSchemas()) {
81 m_schema->loadModule(it);
82 }
Václav Kubernát80aacc02018-08-22 17:41:54 +020083}
84
85std::map<std::string, leaf_data_> SysrepoAccess::getItems(const std::string& path)
86{
Václav Kubernátb6ff0b62018-08-30 16:14:53 +020087 using namespace std::string_literals;
Václav Kubernát80aacc02018-08-22 17:41:54 +020088 std::map<std::string, leaf_data_> res;
Václav Kubernát80aacc02018-08-22 17:41:54 +020089
Václav Kubernátb6ff0b62018-08-30 16:14:53 +020090 auto fillMap = [&res](auto items) {
91 if (!items)
92 return;
93 for (unsigned int i = 0; i < items->val_cnt(); i++) {
94 res.emplace(items->val(i)->xpath(), leafValueFromVal(items->val(i)));
95 }
96 };
Václav Kubernátc89736b2018-08-30 16:14:05 +020097
Václav Kubernátb6ff0b62018-08-30 16:14:53 +020098 if (path == "/") {
99 // Sysrepo doesn't have a root node ("/"), so we take all top-level nodes from all schemas
100 auto schemas = m_session->list_schemas();
101 for (unsigned int i = 0; i < schemas->schema_cnt(); i++) {
102 fillMap(m_session->get_items(("/"s + schemas->schema(i)->module_name() + ":*//.").c_str()));
103 }
104 } else {
105 fillMap(m_session->get_items((path + "//.").c_str()));
Václav Kubernátc89736b2018-08-30 16:14:05 +0200106 }
Václav Kubernát80aacc02018-08-22 17:41:54 +0200107
108 return res;
109}
110
111void SysrepoAccess::setLeaf(const std::string& path, leaf_data_ value)
112{
113 m_session->set_item(path.c_str(), boost::apply_visitor(valFromValue(), value));
114}
115
116void SysrepoAccess::createPresenceContainer(const std::string& path)
117{
118 m_session->set_item(path.c_str());
119}
120
121void SysrepoAccess::deletePresenceContainer(const std::string& path)
122{
123 m_session->delete_item(path.c_str());
124}
Václav Kubernát812ee282018-08-30 17:10:03 +0200125
Václav Kubernátf5f64f02019-03-19 17:15:47 +0100126void SysrepoAccess::createListInstance(const std::string& path)
127{
128 m_session->set_item(path.c_str());
129}
130
131void SysrepoAccess::deleteListInstance(const std::string& path)
132{
133 m_session->delete_item(path.c_str());
134}
135
Václav Kubernát812ee282018-08-30 17:10:03 +0200136void SysrepoAccess::commitChanges()
137{
138 m_session->commit();
139}
Václav Kubernáta6c5fff2018-09-07 15:16:25 +0200140
Václav Kubernát6d791432018-10-25 16:00:35 +0200141void SysrepoAccess::discardChanges()
142{
143 m_session->discard_changes();
144}
145
Václav Kubernáta6c5fff2018-09-07 15:16:25 +0200146std::string SysrepoAccess::fetchSchema(const char* module, const char* revision, const char* submodule)
147{
148 auto schema = m_session->get_schema(module, revision, submodule, SR_SCHEMA_YANG); // FIXME: maybe we should use get_submodule_schema for submodules?
149 if (schema.empty())
150 throw std::runtime_error(std::string("Module ") + module + " not available");
151
152 return schema;
153}
154
155std::vector<std::string> SysrepoAccess::listImplementedSchemas()
156{
157 std::vector<std::string> res;
158 auto schemas = m_session->list_schemas();
159 for (unsigned int i = 0; i < schemas->schema_cnt(); i++) {
160 auto schema = schemas->schema(i);
161 if (schema->implemented())
162 res.push_back(schema->module_name());
163 }
164 return res;
165}
166
167std::shared_ptr<Schema> SysrepoAccess::schema()
168{
169 return m_schema;
170}