wlan-cloud-ucentralgw/src/TelemetryClient.cpp

//
// Created by stephane bourque on 2022-02-03.
//

#include "TelemetryClient.h"
#include "AP_WS_Server.h"
#include "CommandManager.h"
#include "TelemetryStream.h"

#include "Poco/Net/SSLException.h"
#include "fmt/format.h"

namespace OpenWifi {

	TelemetryClient::TelemetryClient(std::string UUID, uint64_t SerialNumber,
									 std::unique_ptr<Poco::Net::WebSocket> WSock,
									 Poco::Net::SocketReactor &Reactor, Poco::Logger &Logger)
		: UUID_(std::move(UUID)), SerialNumber_(SerialNumber), Reactor_(Reactor), Logger_(Logger),
		  WS_(std::move(WSock)) {
		CompleteStartup();
	}

	void TelemetryClient::CompleteStartup() {
		Socket_ = *WS_;
		CId_ = Utils::FormatIPv6(Socket_.peerAddress().toString());

		Poco::Timespan TS(1 * 60 * 60, 0);

		WS_->setReceiveTimeout(TS);
		WS_->setSendTimeout(TS);
		WS_->setNoDelay(true);
		WS_->setKeepAlive(true);
		WS_->setMaxPayloadSize(2048);
		WS_->setBlocking(false);
		Reactor_.addEventHandler(*WS_,
								 Poco::NObserver<TelemetryClient, Poco::Net::ReadableNotification>(
									 *this, &TelemetryClient::OnSocketReadable));
		Reactor_.addEventHandler(*WS_,
								 Poco::NObserver<TelemetryClient, Poco::Net::ShutdownNotification>(
									 *this, &TelemetryClient::OnSocketShutdown));
		Reactor_.addEventHandler(*WS_,
								 Poco::NObserver<TelemetryClient, Poco::Net::ErrorNotification>(
									 *this, &TelemetryClient::OnSocketError));
		Registered_ = true;
		poco_information(Logger(),
						 fmt::format("TELEMETRY-CONNECTION({}): Connection completed.", CId_));
	}

	TelemetryClient::~TelemetryClient() {
		poco_information(Logger(),
						 fmt::format("TELEMETRY-CONNECTION({}): Closing connection.", CId_));
		DeRegister();
	}

	void TelemetryClient::DeRegister() {
		if (Registered_) {
			Registered_ = false;
			Reactor_.removeEventHandler(
				*WS_, Poco::NObserver<TelemetryClient, Poco::Net::ReadableNotification>(
						  *this, &TelemetryClient::OnSocketReadable));
			Reactor_.removeEventHandler(
				*WS_, Poco::NObserver<TelemetryClient, Poco::Net::ShutdownNotification>(
						  *this, &TelemetryClient::OnSocketShutdown));
			Reactor_.removeEventHandler(
				*WS_, Poco::NObserver<TelemetryClient, Poco::Net::ErrorNotification>(
						  *this, &TelemetryClient::OnSocketError));
		}
	}

	bool TelemetryClient::Send(const std::string &Payload) {
		std::lock_guard Guard(Mutex_);
		size_t BytesSent = WS_->sendFrame(Payload.c_str(), (int)Payload.size());
		return BytesSent == Payload.size();
	}

	void TelemetryClient::SendTelemetryShutdown() {
		poco_information(Logger(), fmt::format("TELEMETRY-SHUTDOWN({}): Closing.", CId_));
		DeRegister();
		AP_WS_Server()->StopWebSocketTelemetry(CommandManager()->Next_RPC_ID(), SerialNumber_);
		TelemetryStream()->DeRegisterClient(UUID_);
	}

	void TelemetryClient::OnSocketShutdown(
		[[maybe_unused]] const Poco::AutoPtr<Poco::Net::ShutdownNotification> &pNf) {
		poco_information(Logger(),
						 fmt::format("TELEMETRY-SOCKET-SHUTDOWN({}): Orderly shutdown.", CId_));
		SendTelemetryShutdown();
	}

	void TelemetryClient::OnSocketError(
		[[maybe_unused]] const Poco::AutoPtr<Poco::Net::ErrorNotification> &pNf) {
		poco_information(Logger(), fmt::format("TELEMETRY-SOCKET-ERROR({}): Closing.", CId_));
		SendTelemetryShutdown();
	}

	void TelemetryClient::OnSocketReadable(
		[[maybe_unused]] const Poco::AutoPtr<Poco::Net::ReadableNotification> &pNf) {
		try {
			std::lock_guard Guard(Mutex_);
			return ProcessIncomingFrame();
		} catch (const Poco::Exception &E) {
			Logger().log(E);
		} catch (const std::exception &E) {
			std::string W = E.what();
			poco_information(
				Logger(),
				fmt::format("TELEMETRY-std::exception caught: {}. Connection terminated with {}", W,
							CId_));
		} catch (...) {
			poco_information(
				Logger(),
				fmt::format("TELEMETRY-Unknown exception for {}. Connection terminated.", CId_));
		}
		SendTelemetryShutdown();
	}

	void TelemetryClient::ProcessIncomingFrame() {

		bool MustDisconnect = false;
		Poco::Buffer<char> IncomingFrame(0);

		try {
			int Op, flags;
			int IncomingSize;
			IncomingSize = WS_->receiveFrame(IncomingFrame, flags);
			Op = flags & Poco::Net::WebSocket::FRAME_OP_BITMASK;

			if (IncomingSize == 0 && flags == 0 && Op == 0) {
				poco_information(
					Logger(),
					fmt::format("TELEMETRY-DISCONNECT({}): device has disconnected.", CId_));
				MustDisconnect = true;
			} else {
				if (Op == Poco::Net::WebSocket::FRAME_OP_PING) {
					Logger().debug(
						fmt::format("TELEMETRY-WS-PING({}): received. PONG sent back.", CId_));
					WS_->sendFrame("", 0,
								   (int)Poco::Net::WebSocket::FRAME_OP_PONG |
									   (int)Poco::Net::WebSocket::FRAME_FLAG_FIN);
				} else if (Op == Poco::Net::WebSocket::FRAME_OP_CLOSE) {
					poco_information(
						Logger(),
						fmt::format("TELEMETRY-DISCONNECT({}): device wants to disconnect.", CId_));
					MustDisconnect = true;
				}
			}
		} catch (...) {
			MustDisconnect = true;
		}

		if (!MustDisconnect)
			return;

		SendTelemetryShutdown();
	}

} // namespace OpenWifi