Method onRawDataReceived

app/src/IO/ConnectionManager.cpp:1385–1423

* @brief Forwards raw bytes from device @p deviceId to Console and API Server. */

 * @brief Forwards raw bytes from device @p deviceId to Console and API Server.
 */
void IO::ConnectionManager::onRawDataReceived(int deviceId, const IO::CapturedDataPtr& data)
{
  Q_ASSERT(data);
  Q_ASSERT(!data->data.isEmpty());
  Q_ASSERT(deviceId >= 0);

  if (m_paused)
    return;

  if (m_replyCaptureArmed.load(std::memory_order_acquire)) [[unlikely]] {
    QMutexLocker locker(&m_replyMutex);
    auto it = m_replyBuffers.find(deviceId);
    if (it != m_replyBuffers.end())
      it->append(data->data);
  }

  static auto& console = Console::Handler::instance();
  static auto& server  = API::Server::instance();
  static auto& fileTx  = IO::FileTransmission::instance();

  server.hotpathTxData(data->data);
  console.hotpathRxDeviceData(deviceId, data->data);

  if (fileTx.active()) [[unlikely]]
    fileTx.onRawDataReceived(data->data);

#ifdef BUILD_COMMERCIAL
  static auto& sqliteExport = Sessions::Export::instance();
  sqliteExport.hotpathTxRawBytes(deviceId, data);

  static auto& mqttPublisher = MQTT::Publisher::instance();
  mqttPublisher.hotpathTxRawBytes(deviceId, data);
#endif

#ifdef ENABLE_GRPC
  static auto& grpcServer = API::GRPC::GRPCServer::instance();
  grpcServer.hotpathTxData(data->data);
#endif
}

//--------------------------------------------------------------------------------------------------
// Private helpers