blob: a6388dbf9b8707458afd493c5dff0978ee267ba7 [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
Jan Kundrát68d4a2c2018-10-01 17:17:09 +020051 sysrepo::S_Val operator()(const std::string& value) const
Václav Kubernát80aacc02018-08-22 17:41:54 +020052 {
Jan Kundrát68d4a2c2018-10-01 17:17:09 +020053 return std::make_shared<sysrepo::Val>(value.c_str());
Václav Kubernát80aacc02018-08-22 17:41:54 +020054 }
55
Jan Kundrátbd178362019-02-05 19:00:04 +010056 template <typename T>
57 sysrepo::S_Val operator()(const T& 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);
Václav Kubernát80aacc02018-08-22 17:41:54 +020060 }
61};
62
Václav Kubernát812ee282018-08-30 17:10:03 +020063SysrepoAccess::~SysrepoAccess() = default;
Václav Kubernát80aacc02018-08-22 17:41:54 +020064
65SysrepoAccess::SysrepoAccess(const std::string& appname)
Jan Kundrát68d4a2c2018-10-01 17:17:09 +020066 : m_connection(new sysrepo::Connection(appname.c_str()))
Václav Kubernáta6c5fff2018-09-07 15:16:25 +020067 , m_schema(new YangSchema())
Václav Kubernát80aacc02018-08-22 17:41:54 +020068{
Jan Kundrát68d4a2c2018-10-01 17:17:09 +020069 m_session = std::make_shared<sysrepo::Session>(m_connection);
Václav Kubernáta6c5fff2018-09-07 15:16:25 +020070 m_schema->registerModuleCallback([this](const char* moduleName, const char* revision, const char* submodule) {
71 return fetchSchema(moduleName, revision, submodule);
72 });
73
74 for (const auto& it : listImplementedSchemas()) {
75 m_schema->loadModule(it);
76 }
Václav Kubernát80aacc02018-08-22 17:41:54 +020077}
78
79std::map<std::string, leaf_data_> SysrepoAccess::getItems(const std::string& path)
80{
Václav Kubernátb6ff0b62018-08-30 16:14:53 +020081 using namespace std::string_literals;
Václav Kubernát80aacc02018-08-22 17:41:54 +020082 std::map<std::string, leaf_data_> res;
Václav Kubernát80aacc02018-08-22 17:41:54 +020083
Václav Kubernátb6ff0b62018-08-30 16:14:53 +020084 auto fillMap = [&res](auto items) {
85 if (!items)
86 return;
87 for (unsigned int i = 0; i < items->val_cnt(); i++) {
88 res.emplace(items->val(i)->xpath(), leafValueFromVal(items->val(i)));
89 }
90 };
Václav Kubernátc89736b2018-08-30 16:14:05 +020091
Václav Kubernátb6ff0b62018-08-30 16:14:53 +020092 if (path == "/") {
93 // Sysrepo doesn't have a root node ("/"), so we take all top-level nodes from all schemas
94 auto schemas = m_session->list_schemas();
95 for (unsigned int i = 0; i < schemas->schema_cnt(); i++) {
96 fillMap(m_session->get_items(("/"s + schemas->schema(i)->module_name() + ":*//.").c_str()));
97 }
98 } else {
99 fillMap(m_session->get_items((path + "//.").c_str()));
Václav Kubernátc89736b2018-08-30 16:14:05 +0200100 }
Václav Kubernát80aacc02018-08-22 17:41:54 +0200101
102 return res;
103}
104
105void SysrepoAccess::setLeaf(const std::string& path, leaf_data_ value)
106{
107 m_session->set_item(path.c_str(), boost::apply_visitor(valFromValue(), value));
108}
109
110void SysrepoAccess::createPresenceContainer(const std::string& path)
111{
112 m_session->set_item(path.c_str());
113}
114
115void SysrepoAccess::deletePresenceContainer(const std::string& path)
116{
117 m_session->delete_item(path.c_str());
118}
Václav Kubernát812ee282018-08-30 17:10:03 +0200119
120void SysrepoAccess::commitChanges()
121{
122 m_session->commit();
123}
Václav Kubernáta6c5fff2018-09-07 15:16:25 +0200124
Václav Kubernát6d791432018-10-25 16:00:35 +0200125void SysrepoAccess::discardChanges()
126{
127 m_session->discard_changes();
128}
129
Václav Kubernáta6c5fff2018-09-07 15:16:25 +0200130std::string SysrepoAccess::fetchSchema(const char* module, const char* revision, const char* submodule)
131{
132 auto schema = m_session->get_schema(module, revision, submodule, SR_SCHEMA_YANG); // FIXME: maybe we should use get_submodule_schema for submodules?
133 if (schema.empty())
134 throw std::runtime_error(std::string("Module ") + module + " not available");
135
136 return schema;
137}
138
139std::vector<std::string> SysrepoAccess::listImplementedSchemas()
140{
141 std::vector<std::string> res;
142 auto schemas = m_session->list_schemas();
143 for (unsigned int i = 0; i < schemas->schema_cnt(); i++) {
144 auto schema = schemas->schema(i);
145 if (schema->implemented())
146 res.push_back(schema->module_name());
147 }
148 return res;
149}
150
151std::shared_ptr<Schema> SysrepoAccess::schema()
152{
153 return m_schema;
154}