Method removeNode

pj_datastore/src/derived_engine.cpp:693–728

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

PJ::Status DerivedEngine::removeNode(PJ::NodeId id) {
  auto it = impl_->nodes.find(id);
  if (it == impl_->nodes.end()) {
    return PJ::unexpected(fmt::format("remove_node: node {} not found", id));
  }

  const DerivedNode& node = it->second;

  // Remove from topic_to_nodes
  for (PJ::TopicId in_tid : node.all_input_topic_ids) {
    auto& v = impl_->topic_to_nodes[in_tid];
    v.erase(std::remove(v.begin(), v.end(), id), v.end());
  }

  // Remove from output_topic_to_node and registered_output_names
  for (PJ::TopicId out_tid : node.output_topic_ids) {
    impl_->output_topic_to_node.erase(out_tid);
    // Remove from registered_output_names (scan for the value)
    for (auto sit = impl_->registered_output_names.begin(); sit != impl_->registered_output_names.end(); ++sit) {
      if (sit->second == out_tid) {
        impl_->registered_output_names.erase(sit);
        break;
      }
    }
  }

  // Remove from downstream_of
  impl_->downstream_of.erase(id);
  for (auto dit = impl_->downstream_of.begin(); dit != impl_->downstream_of.end(); ++dit) {
    auto& list = dit.value();
    list.erase(std::remove(list.begin(), list.end(), id), list.end());
  }

  impl_->nodes.erase(it);
  return PJ::okStatus();
}

bool DerivedEngine::hasNode(PJ::NodeId id) const noexcept {
  return impl_->nodes.contains(id);