Added new NodeRegistryClient entity

Author: serges147

include/ocvsmd/sdk/daemon.hpp

@@ -8,6 +8,7 @@
 
 #include "file_server.hpp"
 #include "node_command_client.hpp"
+#include "node_registry_client.hpp"
 
 #include <cetl/cetl.hpp>
 #include <cetl/pf17/cetlpf.hpp>
@@ -67,6 +68,13 @@ class Daemon
     ///
     virtual NodeCommandClient::Ptr getNodeCommandClient() const = 0;
 
+    /// Gets a pointer to the shared entity which represents the Node Registry component of the OCVSMD engine.
+    ///
+    /// @return Shared pointer to the client side of the Node Registry component.
+    ///         The component is always present in the OCVSMD engine, so the result is never `nullptr`.
+    ///
+    virtual NodeRegistryClient::Ptr getNodeRegistryClient() const = 0;
+
 protected:
     Daemon() = default;
 

include/ocvsmd/sdk/node_registry_client.hpp

@@ -0,0 +1,40 @@
+//
+// Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
+// SPDX-License-Identifier: MIT
+//
+
+#ifndef OCVSMD_SDK_NODE_REGISTRY_CLIENT_HPP_INCLUDED
+#define OCVSMD_SDK_NODE_REGISTRY_CLIENT_HPP_INCLUDED
+
+#include <memory>
+
+namespace ocvsmd
+{
+namespace sdk
+{
+
+/// Defines client side interface of the OCVSMD Node Registry component.
+///
+class NodeRegistryClient
+{
+public:
+    /// Defines the shared pointer type for the interface.
+    ///
+    using Ptr = std::shared_ptr<NodeRegistryClient>;
+
+    NodeRegistryClient(NodeRegistryClient&&)                 = delete;
+    NodeRegistryClient(const NodeRegistryClient&)            = delete;
+    NodeRegistryClient& operator=(NodeRegistryClient&&)      = delete;
+    NodeRegistryClient& operator=(const NodeRegistryClient&) = delete;
+
+    virtual ~NodeRegistryClient() = default;
+
+protected:
+    NodeRegistryClient() = default;
+
+};  // NodeRegistryClient
+
+}  // namespace sdk
+}  // namespace ocvsmd
+
+#endif  // OCVSMD_SDK_NODE_REGISTRY_CLIENT_HPP_INCLUDED

src/sdk/CMakeLists.txt

@@ -20,6 +20,7 @@ add_library(ocvsmd_sdk
         daemon.cpp
         file_server.cpp
         node_command_client.cpp
+        node_registry_client.cpp
         svc/node/exec_cmd_client.cpp
         svc/file_server/list_roots_client.cpp
         svc/file_server/pop_root_client.cpp

src/sdk/daemon.cpp

@@ -11,6 +11,7 @@
 #include "ipc/pipe/socket_client.hpp"
 #include "logging.hpp"
 #include "ocvsmd/sdk/node_command_client.hpp"
+#include "ocvsmd/sdk/node_registry_client.hpp"
 #include "sdk_factory.hpp"
 
 #include <cetl/cetl.hpp>
@@ -59,8 +60,9 @@ class DaemonImpl final : public Daemon
 
         ipc_router_ = common::ipc::ClientRouter::make(memory_, std::move(client_pipe));
 
-        file_server_         = Factory::makeFileServer(memory_, ipc_router_);
-        node_command_client_ = Factory::makeNodeCommandClient(memory_, ipc_router_);
+        file_server_          = Factory::makeFileServer(memory_, ipc_router_);
+        node_command_client_  = Factory::makeNodeCommandClient(memory_, ipc_router_);
+        node_registry_client_ = Factory::makeNodeRegistryClient(memory_, ipc_router_);
 
         if (const int err = ipc_router_->start())
         {
@@ -84,13 +86,19 @@ class DaemonImpl final : public Daemon
         return node_command_client_;
     }
 
+    NodeRegistryClient::Ptr getNodeRegistryClient() const override
+    {
+        return node_registry_client_;
+    }
+
 private:
     cetl::pmr::memory_resource&    memory_;
     libcyphal::IExecutor&          executor_;
     common::LoggerPtr              logger_;
     common::ipc::ClientRouter::Ptr ipc_router_;
     FileServer::Ptr                file_server_;
     NodeCommandClient::Ptr         node_command_client_;
+    NodeRegistryClient::Ptr        node_registry_client_;
 
 };  // DaemonImpl
 

src/sdk/node_registry_client.cpp

@@ -0,0 +1,49 @@
+//
+// Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
+// SPDX-License-Identifier: MIT
+//
+
+#include <ocvsmd/sdk/node_registry_client.hpp>
+
+#include "ipc/client_router.hpp"
+#include "logging.hpp"
+#include "sdk_factory.hpp"
+
+#include <cetl/pf17/cetlpf.hpp>
+
+namespace ocvsmd
+{
+namespace sdk
+{
+namespace
+{
+
+class NodeRegistryClientImpl final : public NodeRegistryClient
+{
+public:
+    NodeRegistryClientImpl(cetl::pmr::memory_resource& memory, common::ipc::ClientRouter::Ptr ipc_router)
+        : memory_{memory}
+        , ipc_router_{std::move(ipc_router)}
+        , logger_{common::getLogger("sdk")}
+    {
+    }
+
+    // NodeRegistryClient
+
+private:
+    cetl::pmr::memory_resource&    memory_;
+    common::LoggerPtr              logger_;
+    common::ipc::ClientRouter::Ptr ipc_router_;
+
+};  // NodeRegistryClientImpl
+
+}  // namespace
+
+CETL_NODISCARD NodeRegistryClient::Ptr Factory::makeNodeRegistryClient(cetl::pmr::memory_resource&    memory,
+                                                                       common::ipc::ClientRouter::Ptr ipc_router)
+{
+    return std::make_shared<NodeRegistryClientImpl>(memory, std::move(ipc_router));
+}
+
+}  // namespace sdk
+}  // namespace ocvsmd

src/sdk/sdk_factory.hpp

@@ -8,6 +8,7 @@
 
 #include <ocvsmd/sdk/file_server.hpp>
 #include <ocvsmd/sdk/node_command_client.hpp>
+#include <ocvsmd/sdk/node_registry_client.hpp>
 
 #include "ipc/client_router.hpp"
 
@@ -27,6 +28,9 @@ struct Factory
     CETL_NODISCARD static NodeCommandClient::Ptr makeNodeCommandClient(cetl::pmr::memory_resource&    memory,
                                                                        common::ipc::ClientRouter::Ptr ipc_router);
 
+    CETL_NODISCARD static NodeRegistryClient::Ptr makeNodeRegistryClient(cetl::pmr::memory_resource&    memory,
+                                                                         common::ipc::ClientRouter::Ptr ipc_router);
+
 };  // Factory
 
 }  // namespace sdk