blob: 78d80b1136b676b59760b8a17333e1de27ebf7fd [file] [log] [blame]
Václav Kubernátc31bd602019-03-07 11:44:48 +01001/*
2 * Copyright (C) 2019 CESNET, https://photonics.cesnet.cz/
3 *
4 * Written by Václav Kubernát <kubernat@cesnet.cz>
5 *
6*/
7
8#include <libyang/Libyang.hpp>
9#include <libyang/Tree_Data.hpp>
10#include "netconf-client.h"
11#include "netconf_access.hpp"
12#include "utils.hpp"
13#include "yang_schema.hpp"
14
15leaf_data_ leafValueFromValue(const libyang::S_Value& value, LY_DATA_TYPE type)
16{
17 using namespace std::string_literals;
18 switch (type) {
19 case LY_TYPE_INT8:
20 return value->int8();
21 case LY_TYPE_INT16:
22 return value->int16();
23 case LY_TYPE_INT32:
24 return value->int32();
25 case LY_TYPE_INT64:
26 return value->int64();
27 case LY_TYPE_UINT8:
28 return value->uint8();
29 case LY_TYPE_UINT16:
30 return value->uint16();
31 case LY_TYPE_UINT32:
32 return value->uintu32();
33 case LY_TYPE_UINT64:
34 return value->uint64();
35 case LY_TYPE_BOOL:
Václav Kubernát8e121ff2019-10-15 15:47:45 +020036 return bool(value->bln());
Václav Kubernátc31bd602019-03-07 11:44:48 +010037 case LY_TYPE_STRING:
38 return std::string(value->string());
39 case LY_TYPE_ENUM:
Václav Kubernát152ce222019-12-19 12:23:32 +010040 return enum_{std::string(value->enm()->name())};
Václav Kubernátc31bd602019-03-07 11:44:48 +010041 default: // TODO: implement all types
42 return "(can't print)"s;
43 }
44}
45
46NetconfAccess::~NetconfAccess() = default;
47
48std::map<std::string, leaf_data_> NetconfAccess::getItems(const std::string& path)
49{
50 using namespace std::string_literals;
51 std::map<std::string, leaf_data_> res;
52
53 // This is very similar to the fillMap lambda in SysrepoAccess, however,
54 // Sysrepo returns a weird array-like structure, while libnetconf
55 // returns libyang::Data_Node
56 auto fillMap = [&res](auto items) {
57 for (const auto& it : items) {
58 if (!it)
59 continue;
Václav Kubernátd812cfb2020-01-07 17:30:20 +010060 if (it->schema()->nodetype() == LYS_LIST) {
Václav Kubernát144729d2020-01-08 15:20:35 +010061 res.emplace(it->path(), special_{SpecialValue::List});
Václav Kubernátd812cfb2020-01-07 17:30:20 +010062 }
Václav Kubernátc31bd602019-03-07 11:44:48 +010063 if (it->schema()->nodetype() == LYS_LEAF) {
64 libyang::Data_Node_Leaf_List leaf(it);
65 res.emplace(leaf.path(), leafValueFromValue(leaf.value(), leaf.leaf_type()->base()));
66 }
67 }
68 };
69
Václav Kubernát9456b5c2019-10-02 21:14:52 +020070 auto config = m_session->getConfig(NC_DATASTORE_RUNNING, (path != "/") ? std::optional{path} : std::nullopt);
71
72 if (config) {
73 for (auto it : config->tree_for()) {
Václav Kubernátc31bd602019-03-07 11:44:48 +010074 fillMap(it->tree_dfs());
75 }
Václav Kubernátc31bd602019-03-07 11:44:48 +010076 }
Václav Kubernátc31bd602019-03-07 11:44:48 +010077 return res;
78}
79
80void NetconfAccess::datastoreInit()
81{
Václav Kubernátb52dc252019-12-04 13:03:39 +010082 m_schema->registerModuleCallback([this](const char* moduleName, const char* revision, const char* submodule, const char* submoduleRevision) {
Václav Kubernátc31bd602019-03-07 11:44:48 +010083 return fetchSchema(moduleName,
84 revision ? std::optional{revision} : std::nullopt,
Václav Kubernátb52dc252019-12-04 13:03:39 +010085 submodule ? std::optional{submodule} : std::nullopt,
86 submoduleRevision ? std::optional{submoduleRevision} : std::nullopt);
Václav Kubernátc31bd602019-03-07 11:44:48 +010087 });
88
89 for (const auto& it : listImplementedSchemas()) {
90 m_schema->loadModule(it);
91 }
92}
93
94NetconfAccess::NetconfAccess(const std::string& hostname, uint16_t port, const std::string& user, const std::string& pubKey, const std::string& privKey)
95 : m_schema(new YangSchema())
96{
97 m_session = libnetconf::client::Session::connectPubkey(hostname, port, user, pubKey, privKey);
98 datastoreInit();
99}
100
101NetconfAccess::NetconfAccess(const std::string& socketPath)
102 : m_schema(new YangSchema())
103{
104 m_session = libnetconf::client::Session::connectSocket(socketPath);
105 datastoreInit();
106}
107
108void NetconfAccess::setLeaf(const std::string& path, leaf_data_ value)
109{
110 auto node = m_schema->dataNodeFromPath(path, leafDataToString(value));
111 doEditFromDataNode(node);
112}
113
114void NetconfAccess::createPresenceContainer(const std::string& path)
115{
116 auto node = m_schema->dataNodeFromPath(path);
117 doEditFromDataNode(node);
118}
119
120void NetconfAccess::deletePresenceContainer(const std::string& path)
121{
122 auto node = m_schema->dataNodeFromPath(path);
123 node->insert_attr(m_schema->getYangModule("ietf-netconf"), "operation", "delete");
124 doEditFromDataNode(node);
125}
126
127void NetconfAccess::createListInstance(const std::string& path)
128{
129 auto node = m_schema->dataNodeFromPath(path);
130 doEditFromDataNode(node);
131}
132
133void NetconfAccess::deleteListInstance(const std::string& path)
134{
135 auto node = m_schema->dataNodeFromPath(path);
136 node->child()->insert_attr(m_schema->getYangModule("ietf-netconf"), "operation", "delete");
137 doEditFromDataNode(node);
138}
139
140void NetconfAccess::doEditFromDataNode(std::shared_ptr<libyang::Data_Node> dataNode)
141{
142 auto data = dataNode->print_mem(LYD_XML, 0);
143 m_session->editConfig(NC_DATASTORE_CANDIDATE, NC_RPC_EDIT_DFLTOP_MERGE, NC_RPC_EDIT_TESTOPT_TESTSET, NC_RPC_EDIT_ERROPT_STOP, data);
144}
145
146void NetconfAccess::commitChanges()
147{
148 m_session->commit();
149}
150
151void NetconfAccess::discardChanges()
152{
153 m_session->discard();
154}
155
Václav Kubernátb52dc252019-12-04 13:03:39 +0100156std::string NetconfAccess::fetchSchema(const std::string_view module, const
157 std::optional<std::string_view> revision, const
158 std::optional<std::string_view> submodule, const
159 std::optional<std::string_view> submoduleRevision)
Václav Kubernátc31bd602019-03-07 11:44:48 +0100160{
Václav Kubernátb52dc252019-12-04 13:03:39 +0100161 if (submodule) {
162 return m_session->getSchema(*submodule, submoduleRevision);
163 }
Václav Kubernátc31bd602019-03-07 11:44:48 +0100164 return m_session->getSchema(module, revision);
165}
166
167std::vector<std::string> NetconfAccess::listImplementedSchemas()
168{
169 auto data = m_session->get("/ietf-netconf-monitoring:netconf-state/schemas");
170 auto set = data->find_path("/ietf-netconf-monitoring:netconf-state/schemas/schema/identifier");
171
172 std::vector<std::string> res;
173 for (auto it : set->data()) {
174 if (it->schema()->nodetype() == LYS_LEAF) {
175 libyang::Data_Node_Leaf_List leaf(it);
176 res.push_back(leaf.value_str());
177 }
178 }
179 return res;
180}
181
182std::shared_ptr<Schema> NetconfAccess::schema()
183{
184 return m_schema;
185}