vd_conversation.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_APPL_SRC_DCM_CONVERSATION_VD_CONVERSATION_H
#define DIAG_CLIENT_LIB_APPL_SRC_DCM_CONVERSATION_VD_CONVERSATION_H
 
/* includes */
#include <chrono>
#include <mutex>
#include <string_view>
 
#include "core/include/result.h"
#include "diag-client/dcm/conversation/conversation.h"
#include "diag-client/dcm/conversation/vd_conversation_type.h"
#include "diag-client/diagnostic_client.h"
#include "diag-client/diagnostic_client_uds_message_type.h"
#include "diag-client/diagnostic_client_vehicle_info_message_type.h"
#include "uds_transport/connection.h"
#include "uds_transport/conversation_handler.h"
#include "uds_transport/protocol_types.h"
 
namespace diag {
namespace client {
namespace conversation {
 
class VdConversation final : public Conversation {
 private:
  using PreselectionMode = std::uint8_t;
 
  using PreselectionValue = std::vector<std::uint8_t>;
 
  using VehicleAddrInfoResponseStruct = diag::client::vehicle_info::VehicleAddrInfoResponse;
 
  using LogicalAddress = std::uint16_t;
 
 public:
  VdConversation(std::string_view conversion_name, VDConversationType &conversion_identifier);
 
  VdConversation(const VdConversation &other) noexcept = delete;
  VdConversation &operator=(const VdConversation &other) noexcept = delete;
 
  VdConversation(VdConversation &&other) noexcept = delete;
  VdConversation &operator=(VdConversation &&other) noexcept = delete;
 
  ~VdConversation() override;
 
  void Startup() noexcept override;
 
  void Shutdown() noexcept override;
 
  void RegisterConnection(
      std::unique_ptr<::uds_transport::Connection> connection) noexcept override;
 
  ::uds_transport::ConversionHandler &GetConversationHandler() noexcept override;
 
  std::pair<::uds_transport::UdsTransportProtocolMgr::IndicationResult,
            ::uds_transport::UdsMessagePtr>
  IndicateMessage(::uds_transport::UdsMessage::Address source_addr,
                  ::uds_transport::UdsMessage::Address target_addr,
                  ::uds_transport::UdsMessage::TargetAddressType type,
                  ::uds_transport::ChannelID channel_id, std::size_t size,
                  ::uds_transport::Priority priority, ::uds_transport::ProtocolKind protocol_kind,
                  core_type::Span<std::uint8_t const> payloadInfo) noexcept override;
 
  void HandleMessage(::uds_transport::UdsMessagePtr message) noexcept override;
 
  core_type::Result<diag::client::vehicle_info::VehicleInfoMessageResponseUniquePtr,
                    DiagClient::VehicleInfoResponseError>
  SendVehicleIdentificationRequest(
      vehicle_info::VehicleInfoListRequestType vehicle_info_request) noexcept override;
 
  vehicle_info::VehicleInfoMessageResponseUniquePtr GetDiagnosticServerList();
 
 private:
  bool VerifyVehicleInfoRequest(PreselectionMode preselection_mode,
                                std::uint8_t preselection_value_length);
 
  static std::pair<LogicalAddress, VehicleAddrInfoResponseStruct> DeserializeVehicleInfoResponse(
      ::uds_transport::UdsMessagePtr message);
 
  static std::pair<PreselectionMode, PreselectionValue> DeserializeVehicleInfoRequest(
      vehicle_info::VehicleInfoListRequestType &vehicle_info_request);
 
  std::unique_ptr<::uds_transport::ConversionHandler> vd_conversion_handler_;
 
  std::string conversation_name_;
 
  std::string broadcast_address_;
 
  std::unique_ptr<::uds_transport::Connection> connection_ptr_;
 
  std::map<std::uint16_t, VehicleAddrInfoResponseStruct> vehicle_info_collection_;
 
  std::mutex vehicle_info_container_mutex_;
};
 
}  // namespace conversation
}  // namespace client
}  // namespace diag
#endif  // DIAG_CLIENT_LIB_APPL_SRC_DCM_CONVERSATION_VD_CONVERSATION_H