Method captureTableSnapshots

app/src/Sessions/Export.cpp:792–837

* @brief Main-thread 1 Hz poll: diffs the live data-table store against the last captured * state and enqueues changed registers for the table_snapshots table. */

 *        state and enqueues changed registers for the table_snapshots table.
 */
void Sessions::Export::captureTableSnapshots()
{
  if (!exportEnabled() || !isOpen() || SerialStudio::isAnyPlayerOpen()) {
    m_lastTableSnapshot.clear();
    return;
  }

  const auto& store = DataModel::FrameBuilder::instance().tableStore();
  if (!store.isInitialized())
    return;

  const auto changed =
    [this](const QString& table, const QString& reg, const DataModel::RegisterValue& val) {
      const auto t = m_lastTableSnapshot.constFind(table);
      if (t == m_lastTableSnapshot.constEnd())
        return true;

      const auto r = t.value().constFind(reg);
      if (r == t.value().constEnd())
        return true;

      return r.value().isNumeric != val.isNumeric || r.value().numericValue != val.numericValue
          || r.value().stringValue != val.stringValue;
    };

  const auto now      = DataModel::TimestampedFrame::SteadyClock::now();
  const auto snapshot = store.snapshot();
  for (auto t = snapshot.constBegin(); t != snapshot.constEnd(); ++t) {
    if (t.key() == DataModel::systemDataTableName())
      continue;

    for (auto r = t.value().constBegin(); r != t.value().constEnd(); ++r) {
      if (!changed(t.key(), r.key(), r.value()))
        continue;

      TableSnapshotEntry entry;
      entry.timestamp    = now;
      entry.tableName    = t.key();
      entry.registerName = r.key();
      entry.value        = r.value();
      m_tableSnapshotQueue.try_enqueue(std::move(entry));
    }
  }

  m_lastTableSnapshot = snapshot;
}

/**
 * @brief Enqueues a timestamped frame for SQLite export.