Method objectMergeConflicts

pj_runtime/src/AppSession.cpp:209–246

}

std::vector<ObjectMergeConflict> AppSession::objectMergeConflicts(const std::vector<DatasetId>& selected) const {
  const std::optional<MergePlan> plan = planMerge(selected);
  if (!plan.has_value()) {
    return {};
  }

  const ObjectStore& object_store = session_manager_->objectStore();
  // Mirror ObjectStore::mergeDatasets' grouping so the gate catches EVERY type clash, not just
  // source-vs-anchor: the established type for a name is the anchor's, or — when the anchor lacks it —
  // the FIRST source (in plan order) to contribute that name, which becomes the fuse destination. A
  // later contributor with the same name but a different canonical type is the conflict, whether it
  // disagrees with the anchor or with an earlier source-only contributor.
  std::unordered_map<std::string, sdk::BuiltinObjectType> type_by_name;
  for (const ObjectTopicId object_topic_id : object_store.listTopics(plan->anchor)) {
    const ObjectTopicDescriptor descriptor = object_store.descriptor(object_topic_id);
    type_by_name.emplace(descriptor.topic_name, objectTypeFromMetadata(descriptor.metadata_json));
  }

  std::vector<ObjectMergeConflict> conflicts;
  for (const DatasetMergeSource& source : plan->sources) {
    for (const ObjectTopicId object_topic_id : object_store.listTopics(source.dataset_id)) {
      const ObjectTopicDescriptor descriptor = object_store.descriptor(object_topic_id);
      const sdk::BuiltinObjectType source_type = objectTypeFromMetadata(descriptor.metadata_json);
      const auto [it, inserted] = type_by_name.emplace(descriptor.topic_name, source_type);
      if (inserted || source_type == it->second) {
        continue;  // first contributor for this name (sets the destination type), or a match.
      }
      conflicts.push_back(
          ObjectMergeConflict{
              .topic_name = descriptor.topic_name,
              .source_dataset_id = source.dataset_id,
              .anchor_type = it->second,
              .source_type = source_type,
          });
    }
  }
  return conflicts;
}

DatasetId AppSession::mergeDatasets(const std::vector<DatasetId>& selected) {
  std::optional<MergePlan> plan = planMerge(selected);