Method createDataset

pj_datastore/src/engine.cpp:75–107

// ---------------------------------------------------------------------------

Expected<DatasetId> DataEngine::createDataset(DatasetDescriptor descriptor, DatasetId requested_id) {
  std::unique_lock<std::recursive_mutex> lock(impl_->mutex_);
  DatasetId id = requested_id != 0 ? requested_id : impl_->next_dataset_id;
  if (requested_id != 0) {
    if (impl_->datasets.find(requested_id) != impl_->datasets.end()) {
      return PJ::unexpected(fmt::format("Dataset {} already exists", requested_id));
    }
  }

  // Verify time domain exists if specified
  if (descriptor.time_domain_id != 0) {
    auto it = impl_->time_domains.find(descriptor.time_domain_id);
    if (it == impl_->time_domains.end()) {
      return PJ::unexpected(fmt::format("Time domain {} not found", descriptor.time_domain_id));
    }
  }
  if (requested_id != 0) {
    if (impl_->next_dataset_id <= id) {
      impl_->next_dataset_id = id + 1;
    }
  } else {
    ++impl_->next_dataset_id;
  }

  DatasetInfo info;
  info.id = id;
  info.source_name = std::move(descriptor.source_name);
  if (descriptor.time_domain_id != 0) {
    info.time_domain = impl_->time_domains.at(descriptor.time_domain_id);
  }
  impl_->datasets.emplace(id, std::move(info));
  return id;
}

const DatasetInfo* DataEngine::getDataset(DatasetId id) const {
  auto it = impl_->datasets.find(id);