Method openAndLoad

app/src/Sessions/PlayerLoaderWorker.cpp:158–242

* @brief Opens the file, fetches column order + project JSON + timestamp index, ships it back. */

 * @brief Opens the file, fetches column order + project JSON + timestamp index, ships it back.
 */
void Sessions::PlayerLoaderWorker::openAndLoad(const QString& filePath, int sessionId)
{
  m_cancelRequested.store(false, std::memory_order_release);

  auto payload       = std::make_shared<PlayerSessionPayload>();
  payload->ok        = false;
  payload->filePath  = filePath;
  payload->sessionId = sessionId;

  if (filePath.isEmpty()) {
    payload->error = tr("Empty file path");
    Q_EMIT loaded(payload);
    return;
  }

  const QString connName =
    QStringLiteral("ss_player_loader_%1").arg(QDateTime::currentMSecsSinceEpoch());

  auto closeAndEmit = [&](QSqlDatabase& db) {
    if (db.isOpen())
      db.close();

    db = QSqlDatabase();
    QSqlDatabase::removeDatabase(connName);
    Q_EMIT loaded(payload);
  };

  QSqlDatabase db = QSqlDatabase::addDatabase("QSQLITE", connName);
  db.setDatabaseName(filePath);

  if (!db.open()) {
    payload->error = db.lastError().text();
    closeAndEmit(db);
    return;
  }

  QSqlQuery pragma(db);
  pragma.exec("PRAGMA journal_mode=WAL");
  pragma.exec("PRAGMA busy_timeout=5000");

  if (!resolveSessionId(db, sessionId, payload->error)) {
    closeAndEmit(db);
    return;
  }
  payload->sessionId = sessionId;

  if (m_cancelRequested.load(std::memory_order_acquire)) {
    payload->error = tr("Cancelled");
    closeAndEmit(db);
    return;
  }

  loadProjectJson(db, sessionId, *payload);

  if (!loadColumnOrder(db, sessionId, *payload, payload->error)) {
    closeAndEmit(db);
    return;
  }