nBus-bridge/Core/Src/NbusCommunicator.cpp

/**
 * @file NbusCommunicator.cpp
 * @brief Implementation of hardware communication interface.
 * @date Nov 27, 2025
 * @author Juraj Dudak, Matus Necas
 */

#include "NbusCommunicator.h"

NbusCommunicator::NbusCommunicator(UART_HandleTypeDef *uartNbus, UART_HandleTypeDef *uartMaster)
: _uart_nbus{uartNbus}, _uart_master{uartMaster}
{

}

void NbusCommunicator::sendToMaster(DataFrame *master_frame)
{
	if (master_frame == nullptr || master_frame->IsEmpty())
		return;

	while (_uart_master->gState != HAL_UART_STATE_READY)
    {
        __NOP(); // cakanie na ukoncenie prebiehajuceho odosielania
                 // tu to moze byt vcelku tesno odoslany dalsi paket. je tam pauza o dlzke 1.2bit
    }

    HAL_UART_Transmit_DMA(_uart_master, master_frame->GetFrame(), master_frame->GetLength());
}

void NbusCommunicator::sendToSlave(DataFrame *slaveFrame)
{
    HAL_GPIO_WritePin(GPIOB, GPIO_PIN_3, GPIO_PIN_SET);
    HAL_UART_Transmit(_uart_nbus, slaveFrame->GetFrame(), slaveFrame->GetLength(), NBUS_COMM_UART_TX_TIMEOUT);
    HAL_GPIO_WritePin(GPIOB, GPIO_PIN_3, GPIO_PIN_RESET);
}

DataFrame* NbusCommunicator::sendAndReceiveSlave(DataFrame *slave_frame)
{
    this->sendToSlave(slave_frame);
    this->_receiveFromSlave();
    return &_packet_rx;
}

void NbusCommunicator::_receiveFromSlave()
{
    uint16_t received_size;
    HAL_GPIO_WritePin(GPIOB, GPIO_PIN_3, GPIO_PIN_SET);

    memset(_data_packet_comm, 0, NBUS_COMM_MAX_FRAME_SIZE);
    // DMA communication must be in blocking mode for less overhead
    HAL_StatusTypeDef status = HAL_UARTEx_ReceiveToIdle(_uart_nbus, _data_packet_comm, NBUS_COMM_MAX_FRAME_SIZE,
                                                        &received_size, NBUS_COMM_UART_RX_TIMEOUT);

    _packet_rx.Init();

    if (status == HAL_OK)
    {
        if (received_size > 0)
        {
            _packet_rx.FromArray(_data_packet_comm, received_size);
        }
    }

    HAL_GPIO_WritePin(GPIOB, GPIO_PIN_3, GPIO_PIN_RESET);

    _packet_rx.Commit();
}