Method injectFrame

app/src/CSV/Player.cpp:929–971

* @brief Injects a CSV frame, splitting per source when in multi-source mode. */

 * @brief Injects a CSV frame, splitting per source when in multi-source mode.
 */
void CSV::Player::injectFrame(const QByteArray& frame)
{
  if (frame.isEmpty())
    return;

  if (!m_multiSource) {
    IO::ConnectionManager::instance().processPayload(frame);
    return;
  }

  const QString row = QString::fromUtf8(frame).trimmed();
  const auto fields = DataModel::splitReplayRow(row);

  QMap<int, QStringList> sourceFields;
  QSet<int> sourcesPresent;
  for (auto it = m_sourceColumnsByIndex.constBegin(); it != m_sourceColumnsByIndex.constEnd();
       ++it) {
    const int srcId         = it.key();
    const auto& orderedCols = it.value();
    QStringList orderedCells;
    orderedCells.reserve(orderedCols.size());
    for (int col : orderedCols) {
      const QString cell = (col >= 0 && col < fields.size()) ? fields[col] : QString();
      orderedCells.append(cell);
      if (!cell.isEmpty())
        sourcesPresent.insert(srcId);
    }
    sourceFields.insert(srcId, std::move(orderedCells));
  }

  QMap<int, QByteArray> sourcePayloads;
  for (auto it = sourceFields.constBegin(); it != sourceFields.constEnd(); ++it) {
    if (!sourcesPresent.contains(it.key()))
      continue;

    sourcePayloads[it.key()] = DataModel::joinReplayRow(it.value()) + '\n';
  }

  if (sourcePayloads.isEmpty())
    return;

  IO::ConnectionManager::instance().processMultiSourcePayload(frame, sourcePayloads);
}

//--------------------------------------------------------------------------------------------------
// Event handling