Repurpose into VIS clientneedlefish_13.93.0needlefish/13.93.013.93.0

Repurpose repository for a spiritual successor of the previous
binding.  The replacement is a daemon that demonstrates servicing
the volume actuator from the VSS schema via VIS signals from
KUKSA.val.  Currently the connection to KUKSA.val is websocket based
using the boost::asio framework, but the plan is to migrate to gRPC
as that becomes more robust in KUKSA.val.  As well, this new code
will serve as the base for implementing a gRPC API to expose the full
set of WirePlumber controls as was done with the previous binding.

Notable changes:
- New code is completely C++, partly to leverage using Boost, but
  also to futureproof future work with gRPC.  The WirePlumber
  interfacing code that has been kept from the old binding is
  still C for now, converting it to C++ is a planned future
  rework.
- Switch from CMake to meson for ease of development and some
  degree of futureproofing.
- Use with systemd is assumed; behavior follows the systemd
  daemon guidelines barring the use of journald logging prefixes,
  which may be addressed with future work.  A systemd unit is
  also installed as part of the build.
- SPDX license headers using SPDX "short identifiers" are used in
  source files rather than the full copyright headers used in the
  previous codebase.  This follows the direction that projects such
  as the Linux kernel are going in.

Bug-AGL: SPEC-4409

Signed-off-by: Scott Murray <scott.murray@konsulko.com>
Change-Id: Ibb7091c4354432bb094147d1419ab475486a4abc
(cherry picked from commit 298bbf445a731b85cb8d5d19a3b595e8870d8701)

1 files changed, 78 insertions, 0 deletions

diff --git a/src/vis-session.hpp b/src/vis-session.hpp
new file mode 100644
index 0000000..8c7b0d9
--- /dev/null
+++ b/src/vis-session.hpp
@@ -0,0 +1,78 @@
+// SPDX-License-Identifier: Apache-2.0
+
+#ifndef _VIS_SESSION_HPP
+#define _VIS_SESSION_HPP
+
+#include "vis-config.hpp"
+#include <atomic>
+#include <string>
+#include <boost/beast/core.hpp>
+#include <boost/beast/ssl.hpp>
+#include <boost/beast/websocket.hpp>
+#include <boost/beast/websocket/ssl.hpp>
+#include <boost/asio/strand.hpp>
+#include <nlohmann/json.hpp>
+
+namespace beast = boost::beast;
+namespace websocket = beast::websocket;
+namespace net = boost::asio;
+namespace ssl = boost::asio::ssl;
+using tcp = boost::asio::ip::tcp;
+using json = nlohmann::json;
+
+
+class VisSession : public std::enable_shared_from_this<VisSession>
+{
+	//net::io_context m_ioc;
+	tcp::resolver m_resolver;
+	tcp::resolver::results_type m_results;
+	std::string m_hostname;
+	websocket::stream<beast::ssl_stream<beast::tcp_stream>> m_ws;
+	beast::flat_buffer m_buffer;
+
+public:
+	// Resolver and socket require an io_context
+	explicit VisSession(const VisConfig &config, net::io_context& ioc, ssl::context& ctx);
+
+	// Start the asynchronous operation
+	void run();
+
+protected:
+	VisConfig m_config;
+	std::atomic_uint m_requestid;
+
+	void on_resolve(beast::error_code error, tcp::resolver::results_type results);
+
+	void connect();
+
+	void on_connect(beast::error_code error, tcp::resolver::results_type::endpoint_type endpoint);
+
+	void on_ssl_handshake(beast::error_code error);
+
+	void on_handshake(beast::error_code error);
+
+	void on_authorize(beast::error_code error, std::size_t bytes_transferred);
+
+	void on_write(beast::error_code error, std::size_t bytes_transferred);
+
+	void on_read(beast::error_code error, std::size_t bytes_transferred);
+
+	void get(const std::string &path);
+
+	void set(const std::string &path, const std::string &value);
+
+	void subscribe(const std::string &path);
+
+	void handle_message(const json &message);
+
+	bool parseData(const json &message, std::string &path, std::string &value, std::string &timestamp);
+
+	virtual void handle_authorized_response(void) = 0;
+
+	virtual void handle_get_response(std::string &path, std::string &value, std::string &timestamp) = 0;
+
+	virtual void handle_notification(std::string &path, std::string &value, std::string &timestamp) = 0;
+
+};
+
+#endif // _VIS_SESSION_HPP