socket_handler.h

Go to the documentation of this file.

/* Diagnostic Client library
 * Copyright (C) 2024  Avijit Dey
 * 
 * This Source Code Form is subject to the terms of the Mozilla Public
 * License, v. 2.0. If a copy of the MPL was not distributed with this
 * file, You can obtain one at http://mozilla.org/MPL/2.0/.
 */
#ifndef DIAG_CLIENT_LIB_LIB_DOIP_CLIENT_SOCKETS_SOCKET_HANDLER_H_
#define DIAG_CLIENT_LIB_LIB_DOIP_CLIENT_SOCKETS_SOCKET_HANDLER_H_
 
#include <string_view>
 
#include "boost-support/client/tcp/tcp_client.h"
#include "boost-support/client/udp/udp_client.h"
#include "core/include/result.h"
 
namespace doip_client {
namespace sockets {
 
template<typename ClientType>
class SocketHandler final {
 public:
  using Client = ClientType;
 
  using Message = typename Client::Message;
 
  using MessagePtr = typename Client::MessagePtr;
 
  using MessageConstPtr = typename Client::MessageConstPtr;
 
  using HandlerRead = std::function<void(MessagePtr)>;
 
  explicit SocketHandler(Client client) noexcept : client_{std::move(client)} {}
 
  SocketHandler(const SocketHandler &other) noexcept = delete;
  SocketHandler &operator=(const SocketHandler &other) noexcept = delete;
 
  SocketHandler(SocketHandler &&other) noexcept = default;
  SocketHandler &operator=(SocketHandler &&other) noexcept = default;
 
  ~SocketHandler() = default;
 
  void Initialize() noexcept { client_.Initialize(); }
 
  void DeInitialize() noexcept { client_.DeInitialize(); }
 
  void SetReadHandler(HandlerRead read_handler) { client_.SetReadHandler(std::move(read_handler)); }
 
  core_type::Result<void> ConnectToHost(std::string_view host_ip_address,
                                        std::uint16_t host_port_num) {
    return client_.ConnectToHost(host_ip_address, host_port_num);
  }
 
  core_type::Result<void> DisconnectFromHost() { return client_.DisconnectFromHost(); }
 
  auto IsConnectedToHost() const noexcept -> bool { return client_.IsConnectedToHost(); }
 
  core_type::Result<void> Transmit(MessageConstPtr message) {
    return client_.Transmit(std::move(message));
  }
 
 private:
  Client client_;
};
 
using TcpSocketHandler = SocketHandler<boost_support::client::tcp::TcpClient>;
 
using UdpSocketHandler = SocketHandler<boost_support::client::udp::UdpClient>;
 
}  // namespace sockets
}  // namespace doip_client
#endif  // DIAG_CLIENT_LIB_LIB_DOIP_CLIENT_SOCKETS_SOCKET_HANDLER_H_