Václav Kubernát | 48e9dfa | 2020-07-08 10:55:12 +0200 | [diff] [blame] | 1 | /* |
| 2 | * Copyright (C) 2020 CESNET, https://photonics.cesnet.cz/ |
| 3 | * |
| 4 | * Written by Václav Kubernát <kubernat@cesnet.cz> |
| 5 | * |
| 6 | */ |
| 7 | |
| 8 | #pragma once |
| 9 | #include "datastore_access.hpp" |
Václav Kubernát | e7248b2 | 2020-06-26 15:38:59 +0200 | [diff] [blame] | 10 | #include "yang_access.hpp" |
Václav Kubernát | 48e9dfa | 2020-07-08 10:55:12 +0200 | [diff] [blame] | 11 | |
| 12 | /*! \class ProxyDatastore |
| 13 | * \brief DatastoreAccess wrapper that handles RPC input |
| 14 | */ |
| 15 | class ProxyDatastore { |
| 16 | public: |
Václav Kubernát | e7248b2 | 2020-06-26 15:38:59 +0200 | [diff] [blame] | 17 | /** |
| 18 | * The createTemporaryDatastore function should create a temporary datastore that's going to be used for RPC input. |
| 19 | * This temporary datastore and the main datastore are supposed share the same schemas. |
| 20 | * */ |
| 21 | ProxyDatastore(const std::shared_ptr<DatastoreAccess>& datastore, std::function<std::shared_ptr<DatastoreAccess>(const std::shared_ptr<DatastoreAccess>&)> createTemporaryDatastore); |
Václav Kubernát | 48e9dfa | 2020-07-08 10:55:12 +0200 | [diff] [blame] | 22 | [[nodiscard]] DatastoreAccess::Tree getItems(const std::string& path) const; |
| 23 | void setLeaf(const std::string& path, leaf_data_ value); |
| 24 | void createItem(const std::string& path); |
| 25 | void deleteItem(const std::string& path); |
| 26 | void moveItem(const std::string& source, std::variant<yang::move::Absolute, yang::move::Relative> move); |
| 27 | void commitChanges(); |
| 28 | void discardChanges(); |
| 29 | void copyConfig(const Datastore source, const Datastore destination); |
| 30 | [[nodiscard]] std::string dump(const DataFormat format) const; |
| 31 | |
Václav Kubernát | e7248b2 | 2020-06-26 15:38:59 +0200 | [diff] [blame] | 32 | void initiateRpc(const std::string& rpcPath); |
| 33 | [[nodiscard]] DatastoreAccess::Tree executeRpc(); |
| 34 | void cancelRpc(); |
| 35 | |
Václav Kubernát | 48e9dfa | 2020-07-08 10:55:12 +0200 | [diff] [blame] | 36 | [[nodiscard]] std::shared_ptr<Schema> schema() const; |
| 37 | private: |
Václav Kubernát | e7248b2 | 2020-06-26 15:38:59 +0200 | [diff] [blame] | 38 | /** @brief Picks a datastore based on the requested path. |
| 39 | * |
| 40 | * If the path starts with a currently processed RPC, m_inputDatastore is picked. |
| 41 | * Otherwise m_datastore is picked. |
| 42 | */ |
| 43 | [[nodiscard]] std::shared_ptr<DatastoreAccess> pickDatastore(const std::string& path) const; |
| 44 | |
Václav Kubernát | 48e9dfa | 2020-07-08 10:55:12 +0200 | [diff] [blame] | 45 | std::shared_ptr<DatastoreAccess> m_datastore; |
Václav Kubernát | e7248b2 | 2020-06-26 15:38:59 +0200 | [diff] [blame] | 46 | std::function<std::shared_ptr<DatastoreAccess>(const std::shared_ptr<DatastoreAccess>&)> m_createTemporaryDatastore; |
| 47 | std::shared_ptr<DatastoreAccess> m_inputDatastore; |
| 48 | std::string m_rpcPath; |
Václav Kubernát | 48e9dfa | 2020-07-08 10:55:12 +0200 | [diff] [blame] | 49 | }; |