tcp_message.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_BOOST_SUPPORT_SOCKET_TCP_TCP_MESSAGE_H_
#define DIAG_CLIENT_LIB_LIB_BOOST_SUPPORT_SOCKET_TCP_TCP_MESSAGE_H_
 
#include <cstdint>
#include <memory>
#include <string>
#include <string_view>
#include <vector>
 
#include "core/include/span.h"
 
namespace boost_support {
namespace message {
namespace tcp {
 
class TcpMessage final {
 public:
  enum class SocketState : std::uint8_t {
    kIdle = 0x00,
    kSocketOnline,
    kSocketOffline,
    kSocketRxMessageReceived,
    kSocketTxMessageSend,
    kSocketTxMessageConf,
    kSocketError
  };
 
  enum class SocketError : std::uint8_t { kNone = 0x00 };
 
  using BufferType = std::vector<std::uint8_t>;
 
  using IpAddressType = std::string_view;
 
 public:
  TcpMessage(IpAddressType host_ip_address, std::uint16_t host_port_number, BufferType payload)
      : socket_state_{SocketState::kIdle},
        socket_error_{SocketError::kNone},
        payload_{std::move(payload)},
        host_ip_address_{host_ip_address},
        host_port_number_{host_port_number} {}
 
  TcpMessage(TcpMessage &&other) noexcept = default;
  TcpMessage &operator=(TcpMessage &&other) noexcept = default;
 
  TcpMessage(const TcpMessage &other) = default;
  TcpMessage &operator=(const TcpMessage &other) = default;
 
  ~TcpMessage() = default;
 
  IpAddressType GetHostIpAddress() const { return host_ip_address_; }
 
  std::uint16_t GetHostPortNumber() const { return host_port_number_; }
 
  core_type::Span<std::uint8_t const> GetPayload() const {
    return core_type::Span<std::uint8_t const>{payload_};
  }
 
  SocketState GetSocketState() const { return socket_state_; }
 
  SocketError GetSocketError() const { return socket_error_; }
 
 private:
  SocketState socket_state_;
 
  SocketError socket_error_;
 
  BufferType payload_;
 
  std::string host_ip_address_;
 
  std::uint16_t host_port_number_;
};
 
using TcpMessageConstPtr = std::unique_ptr<TcpMessage const>;
 
using TcpMessagePtr = std::unique_ptr<TcpMessage>;
 
constexpr std::uint8_t kDoipheadrSize = 8U;
 
}  // namespace tcp
}  // namespace message
}  // namespace boost_support
#endif  // DIAG_CLIENT_LIB_LIB_BOOST_SUPPORT_SOCKET_TCP_TCP_MESSAGE_H_