Method resolveInputTopic

pj_runtime/src/DataProcessorService.cpp:307–319

}

std::optional<std::pair<TopicId, DatasetId>> DataProcessorService::resolveInputTopic(const std::string& name) const {
  // No name->id index on the engine; scan live topics (retired ones are excluded
  // from listTopics, which is what we want — a stale output never resolves).
  for (const DatasetId ds : engine_.listDatasets()) {
    for (const TopicId tid : engine_.listTopics(ds)) {
      const TopicStorage* storage = engine_.getTopicStorage(tid);
      if (storage != nullptr && storage->descriptor().name == name) {
        return std::make_pair(tid, ds);
      }
    }
  }
  return std::nullopt;
}

std::optional<DataProcessorService::ResolvedInput> DataProcessorService::resolveInputField(
    const std::string& name) const {